// Usage: node minimal-reproduction.mjs /absolute/path/dist/index.js rate|receipt [output-dir]
import {createServer} from 'node:http';
import {spawn} from 'node:child_process';
import {mkdirSync,mkdtempSync,writeFileSync} from 'node:fs';
import {resolve,join} from 'node:path';
const cli=resolve(process.argv[2]),kind=process.argv[3],n=kind==='rate'?26:2;
if(!['rate','receipt'].includes(kind))throw Error('Select rate or receipt');
const dir=process.argv[4]?resolve(process.argv[4]):mkdtempSync(resolve('testsprite-repro-'));
mkdirSync(dir,{recursive:true});mkdirSync(join(dir,'fixture-user'),{recursive:true});
const save=(name,x)=>writeFileSync(join(dir,name),typeof x==='string'?x:JSON.stringify(x,null,2)+'\n');
const ids=Array.from({length:n},(_,i)=>'fixture_'+i),attempts=new Map(),requests=[];
const plans=ids.map(name=>({projectId:'fixture-project',type:'frontend',name,planSteps:[{type:'action',description:'open fixture'}]}));
save('plans.jsonl',plans.map(x=>JSON.stringify(x)).join('\n')+'\n');
save('isolate.mjs',`import os from 'node:os';import {syncBuiltinESMExports} from 'node:module';os.homedir=()=>process.env.REPRO_USER;syncBuiltinESMExports();const f=globalThis.fetch;globalThis.fetch=(i,o)=>{const u=new URL(typeof i==='string'||i instanceof URL?i:i.url);if(u.origin!==process.env.REPRO_ENDPOINT)throw Error('Nonfixture network blocked');return f(i,o);};`);
let child,signalAt=null;const started=performance.now();
const server=createServer(async(req,res)=>{
 const chunks=[];for await(const b of req)chunks.push(b);
 const path=new URL(req.url,'http://127.0.0.1').pathname.replace('/api/cli/v1','');
 const row={ms:performance.now()-started,method:req.method,path,body:chunks.length?JSON.parse(Buffer.concat(chunks)):null};requests.push(row);
 const reply=(status,body,headers={})=>{row.status=status;row.response=body;res.writeHead(status,{'content-type':'application/json',...headers});res.end(JSON.stringify(body));};
 if(path.endsWith('/env'))return reply(200,{environments:[]});
 if(path==='/tests/batch')return reply(201,{results:ids.map((testId,specIndex)=>({testId,specIndex,status:'created'})),summary:{total:n,created:n,failed:0}});
 const m=/^\/tests\/(fixture_\d+)\/runs$/.exec(path);
 if(m){const id=m[1],count=(attempts.get(id)??0)+1;attempts.set(id,count);
  if(kind==='rate'&&count===1)return reply(503,{error:{code:'UNAVAILABLE',message:'fixture outage',requestId:'fixture'}});
  if(kind==='receipt'&&id===ids[1]){reply(429,{error:{code:'RATE_LIMITED',message:'Run trigger rate limit exceeded: 60 triggers per minute per key.',requestId:'fixture'}},{'retry-after':'10'});setTimeout(()=>{signalAt=performance.now()-started;child.kill('SIGINT');},350);return;}
  return reply(200,{runId:'run_'+id,status:'queued',enqueuedAt:'2026-10-11T00:00:00Z',codeVersion:'v1',targetUrl:'https://fixture.invalid'});
 }
 reply(404,{error:{code:'NOT_FOUND',message:'unexpected route',requestId:'fixture'}});
});
await new Promise(r=>server.listen(0,'127.0.0.1',r));
const endpoint=`http://127.0.0.1:${server.address().port}`;
const argv=['--import',join(dir,'isolate.mjs'),cli,'test','create-batch','--plans',join(dir,'plans.jsonl'),'--run','--max-concurrency',String(n),'--output','json','--endpoint-url',endpoint];
const env={PATH:process.env.PATH,CI:'true',NO_COLOR:'1',TESTSPRITE_API_KEY:'sk-user-fixture-not-a-real-key',TESTSPRITE_NO_TELEMETRY:'1',TESTSPRITE_NO_UPDATE_NOTIFIER:'1',REPRO_USER:join(dir,'fixture-user'),REPRO_ENDPOINT:endpoint};
for(const k of ['HOME','home','CODEX_HOME'])if(process.env[k]!==undefined)env[k]=process.env[k];
save('command.json',{argv:[process.execPath,...argv],cwd:dir,syntheticEnvironment:true});
child=spawn(process.execPath,argv,{cwd:dir,env,stdio:['ignore','pipe','pipe']});let stdout='',stderr='',watchdog=false;
child.stdout.on('data',b=>stdout+=b);child.stderr.on('data',b=>stderr+=b);
const timer=setTimeout(()=>{watchdog=true;child.kill('SIGKILL');},15000);
const exit=await new Promise(r=>child.on('close',(code,signal)=>r({code,signal})));clearTimeout(timer);server.closeAllConnections();await new Promise(r=>server.close(r));
const triggers=requests.filter(q=>q.method==='POST'&&q.path.endsWith('/runs')),span=triggers.at(-1).ms-triggers[0].ms;
let preserved=false;try{const j=JSON.parse(stdout);preserved=j.results.length===n&&j.results.some(x=>x.runId==='run_fixture_0');}catch{}
const violated=kind==='rate'?triggers.length>50&&span<59500:!preserved;
const result={kind,exit,watchdog,signalAt,posts:triggers.length,spanMs:span,stdoutBytes:Buffer.byteLength(stdout),violated,fixtureValid:exit.code===(kind==='rate'?0:130)&&!watchdog&&attempts.size===n};
for(const [name,value] of Object.entries({'requests.json':requests,'stdout.txt':stdout,'stderr.txt':stderr,'result.json':result}))save(name,value);
console.log(JSON.stringify(result));process.exitCode=!result.fixtureValid?2:violated?1:0;