tricu

backend-resume-probe.mjs (2476B)

---

 // Exercise actual page-facing request IDs, independently of private runtime IO.
 export async function probeResume(backend){
  const worker=new Worker(new URL('./wasm-worker.js?backend='+backend,document.querySelector('script[type=module][src]').src),{type:'module'}),events=[];
  worker.onmessage=e=>events.push(e.data);
  const assert=(ok,message)=>{if(!ok)throw Error(message);};
  const sleep=()=>new Promise(r=>setTimeout(r,40));
  const wait=async(predicate,start=0)=>{
   const deadline=performance.now()+10000;
   while(performance.now()<deadline){const messages=events.slice(start);const failure=messages.find(x=>x.type==='error');if(failure)throw Error(failure.message);const found=messages.find(predicate);if(found)return found;await sleep();}
   throw Error('Resume probe timed out');
  };
  try{
   worker.postMessage({type:'compile',source:'main = t "tricuIO" (t 1 (t 11 t))'});
   await wait(x=>x.type==='compiled');
   const run={type:'run',export:'main',arguments:[],output:'string',mode:'io',step:true};
   worker.postMessage(run);const step=await wait(x=>x.type==='state'&&x.state==='step');
   worker.postMessage({type:'resume',id:step.id,value:'wrong-kind'});
   worker.postMessage({type:'resume',id:step.id+999});await sleep();
   assert(!events.some(x=>x.type==='error'||x.type==='done'||x.state==='input'),'Malformed/stale step consumed pending wait');
   worker.postMessage({type:'resume',id:step.id});const input=await wait(x=>x.type==='state'&&x.state==='input');
   for(const value of [undefined,'bad\nline','\ud800','a'.repeat(257)])worker.postMessage({type:'resume',id:input.id,value});
   worker.postMessage({type:'resume',id:step.id,value:'stale'});await sleep();
   assert(!events.some(x=>x.type==='error'||x.type==='done'),'Invalid line consumed pending wait');
   worker.postMessage({type:'resume',id:input.id,value:'λ雪🙂'});
   assert((await wait(x=>x.type==='done')).result.value==='λ雪🙂','Resume value mismatch');
   const mark=events.length;worker.postMessage({...run,step:false});
   const next=await wait(x=>x.type==='state'&&x.state==='input',mark);assert(next.id>input.id,'Request IDs reused');
   worker.postMessage({type:'resume',id:input.id,value:'stale'});await sleep();
   assert(!events.slice(mark).some(x=>x.type==='done'),'Previous run token accepted');
   worker.postMessage({type:'resume',id:next.id,value:'fresh'});
   assert((await wait(x=>x.type==='done',mark)).result.value==='fresh','Fresh run failed');
  }finally{worker.terminate();}
 }