// Node22. Usage: node reproduce.mjs /absolute/path/to/upstream/dist/index.js [output-dir]
// Synthetic loopback only. Exit1 = regression reproduced; exit2 = fixture failure.
import {createServer} from 'node:http';
import {spawn,spawnSync} from 'node:child_process';
import {mkdirSync,writeFileSync,readFileSync} from 'node:fs';
import {resolve,join,dirname} from 'node:path';
import {createHash} from 'node:crypto';
const binary=resolve(process.argv[2]??'upstream/dist/index.js');
const out=resolve(process.argv[3]??'candidates/batch-resume-interrupt-loses-receipts/results');mkdirSync(out,{recursive:true});
const save=(p,x)=>writeFileSync(p,typeof x==='string'?x:JSON.stringify(x,null,2)+'\n');
const date='2026-10-11T20:00:00Z';
const row=id=>({runId:id,testId:id==='run_new'?'test_new':'test_busy',projectId:'project_lab',userId:'lab',status:'passed',source:'cli',createdAt:date,startedAt:date,finishedAt:date,codeVersion:'v1',targetUrl:'https://fixture.invalid',createdFrom:'cli',failedStepIndex:null,failureKind:null,error:null,videoUrl:null,stepSummary:{total:1,completed:1,passedCount:1,failedCount:0}});
const scenarios=[
 {name:'normal-two-members'},
 {name:'metadata-before-headers-SIGINT',stage:'metadata',signal:'SIGINT',exit:130},
 {name:'metadata-partial-body-SIGTERM',stage:'metadata',signal:'SIGTERM',exit:143,partial:true},
 {name:'poll-stage-SIGINT-control',stage:'poll',signal:'SIGINT',exit:130},
 {name:'metadata-before-headers-text',stage:'metadata',signal:'SIGINT',exit:130,text:true},
 {name:'followup-wait-known-new-id',wait:true},
];
const results=[];
for(const s of scenarios){
 const dir=join(out,s.name);mkdirSync(dir,{recursive:true});const userDir=join(dir,'fixture-user');mkdirSync(userDir,{recursive:true});const preload=join(dir,'isolate.mjs');
 save(preload,"import os from 'node:os';import {syncBuiltinESMExports} from 'node:module';os.homedir=()=>process.env.LAB_USER;syncBuiltinESMExports();const f=globalThis.fetch;globalThis.fetch=(u,o)=>{const v=new URL(typeof u==='string'||u instanceof URL?u:u.url);if(v.origin!==process.env.LAB_API)throw Error('Non-fixture origin blocked');return f(u,o);};\n");
 const requests=[],events=[];const t0=performance.now();let child,timer,signalled=false;
 const time=()=>Math.round(performance.now()-t0);
 const batch={accepted:[{testId:'test_new',runId:'run_new',enqueuedAt:date}],conflicts:[{testId:'test_busy',currentRunId:'run_busy',reason:'run_in_flight'}],deferred:[],skippedFrontend:[],skippedIntegration:[]};
 const server=createServer(async(req,res)=>{
  const chunks=[];for await(const b of req)chunks.push(b);const raw=Buffer.concat(chunks).toString();const url=new URL(req.url,'http://127.0.0.1');const path=url.pathname.replace('/api/cli/v1','');const q={atMs:time(),method:req.method,path,query:Object.fromEntries(url.searchParams),body:raw?JSON.parse(raw):null};requests.push(q);res.once('close',()=>events.push({atMs:time(),event:'close',path,finished:res.writableFinished}));
  let body;
  if(path==='/projects/project_lab/env')body={environments:[]};
  else if(path==='/tests/batch/run')body=batch;
  else if(path.startsWith('/runs/')){
   const stage=url.searchParams.has('waitSeconds')?'poll':'metadata';
   if(s.stage===stage){if(s.partial){res.writeHead(200,{'content-type':'application/json'});res.write('{"runId":"run_busy"');}if(!signalled){signalled=true;timer=setTimeout(()=>{events.push({atMs:time(),event:'signal',signal:s.signal});child.kill(s.signal);},150);}return;}
   body=row(path.slice('/runs/'.length));
  }else{q.fixtureError='Unexpected route';res.writeHead(500);res.end('{}');return;}
  q.response=body;res.writeHead(200,{'content-type':'application/json'});res.end(JSON.stringify(body));
 });
 await new Promise(r=>server.listen(0,'127.0.0.1',r));const api=`http://127.0.0.1:${server.address().port}`;
 const args=['--import',preload,binary,...(s.wait?['test','wait','run_new']:['test','run','--all','--project','project_lab','--wait','--max-concurrency','1']),'--timeout','5','--output',s.text?'text':'json','--endpoint-url',api];
 const env={PATH:'/usr/bin:/bin',CI:'true',NO_COLOR:'1',TESTSPRITE_API_KEY:'sk-user-lab-placeholder-not-a-real-key',TESTSPRITE_NO_UPDATE_NOTIFIER:'1',TESTSPRITE_NO_TELEMETRY:'1',LAB_USER:userDir,LAB_API:api};for(const k of ['HOME','home','CODEX_HOME'])if(process.env[k]!==undefined)env[k]=process.env[k];
 save(join(dir,'input.json'),{scenario:s,batch});save(join(dir,'command.json'),{argv:[process.execPath,...args],cwd:dir,syntheticEnv:{...env,HOME:'inherited unchanged',home:'inherited if present',CODEX_HOME:'inherited if present'}});
 child=spawn(process.execPath,args,{env,cwd:dir,stdio:['ignore','pipe','pipe']});let stdout='',stderr='',watchdog=false;
 child.stdout.on('data',b=>stdout+=b);child.stderr.on('data',b=>stderr+=b);const killer=setTimeout(()=>{watchdog=true;child.kill('SIGKILL');},8000);
 const exit=await new Promise((r,j)=>{child.on('error',j);child.on('close',(code,signal)=>r({code,signal}));});clearTimeout(killer);clearTimeout(timer);events.push({event:'exit',atMs:time(),...exit});server.closeAllConnections();await new Promise(r=>server.close(r));
 let json;try{json=JSON.parse(stdout);}catch{}
 const receipt=s.text?stdout.includes('run_new'):(s.wait?json?.runId==='run_new':json?.accepted?.some(x=>x.runId==='run_new'));
 const fixturesPass=exit.code===(s.exit??0)&&!watchdog&&requests.every(x=>!x.fixtureError)&&requests.filter(x=>x.method==='POST').length===(s.wait?0:1)&&requests.every(x=>x.method!=='DELETE');
 const r={scenario:s.name,exit,watchdog,elapsedMs:time(),fixtureChecksPass:fixturesPass,expected:{exit:s.exit??0,newRunReceipt:true},actual:{receipt:Boolean(receipt),stdoutBytes:stdout.length,stderrContainsNewRunId:stderr.includes('run_new')}};
 for(const [name,data] of Object.entries({'stdout.txt':stdout,'stderr.txt':stderr,'requests.json':requests,'events.json':events,'result.json':r}))save(join(dir,name),data);
 results.push(r);console.log(JSON.stringify(r));
}
const fixtureFailures=results.filter(x=>!x.fixtureChecksPass),regressions=results.filter(x=>!x.actual.receipt);const summary={node:process.version,sha:spawnSync('git',['-C',dirname(dirname(binary)),'rev-parse','HEAD'],{encoding:'utf8'}).stdout.trim(),binarySha256:createHash('sha256').update(readFileSync(binary)).digest('hex'),cases:results.length,fixtureFailures,regressions,results};save(join(out,'summary.json'),summary);process.exitCode=fixtureFailures.length?2:regressions.length?1:0;