tricu

backend-resume-probe.mjs (3732B)

---

 // Actual page-facing step IDs and run-bound v2 terminal replies.
 export async function probeResume(backend){
  const base=new URL('../',document.querySelector('script[type=module][src]').src);
  const api=await import(new URL('dist/probe-api.js',base)),{Terminal}=api.ioTerminal;
  const releases=api.packages.packageIndex(await(await fetch(new URL('packages.json',base))).json());
  const lib=name=>api.packages.packageReleases(releases,'tricu-lib-'+name)[0].manifest;
  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);},sleep=()=>new Promise(r=>setTimeout(r,40));
  let consumedStep=0;
  const wait=async(predicate,start=0,stepping=false)=>{
   const deadline=performance.now()+30000;
   while(performance.now()<deadline){
    const messages=events.slice(start),failure=messages.find(x=>x.type==='error');if(failure)throw Error(failure.message);
    const found=messages.find(predicate);if(found)return found;
    if(stepping){const step=messages.find(x=>x.type==='state'&&x.state==='step'&&x.id>consumedStep);if(step){consumedStep=step.id;worker.postMessage({type:'resume',id:step.id});}}
    await sleep();
   }
   throw Error('Resume probe timed out');
  };
  const reply=value=>worker.postMessage({type:'io-command',command:{run:value.run,kind:'reply',reply:value}});
  try{
   worker.postMessage({type:'compile',source:`!import ${lib('io')} as I
 !import ${lib('io-text')} as T
 !export main
 main = I.io (I.require I.stdin (reader : I.require (T.readLine (T.lineCursor reader) 256) (reply : case reply of
   [["line" value _] _] = I.pure value
   _ = I.fail "Invalid reply")))`});
   await wait(x=>x.type==='compiled');
   const run={type:'run-io',name:'main',output:'string',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.type==='io-event'),'Malformed/stale step consumed wait');
   const input=(await wait(x=>x.type==='io-event'&&x.event.kind==='read',0,true)).event;
   const terminal=new Terminal(input.run);terminal.handle(input);
   for(const value of [undefined,'bad\nline','\ud800','a'.repeat(257)])assert(!terminal.line(input.run,input.id,value),'Invalid UI line admitted');
   for(const invalid of [
    {run:input.run,id:input.id,kind:'write',count:1},
    {run:input.run,id:input.id,kind:'read',bytes:[256],eof:false},
    {run:input.run,id:input.id,kind:'read',bytes:[],eof:false},
    {run:input.run,id:input.id+999,kind:'read',bytes:[65],eof:false},
   ])reply(invalid);
   worker.postMessage({type:'resume',id:step.id,value:'stale'});await sleep();
   assert(!events.some(x=>x.type==='done'||x.type==='error'),'Invalid reply consumed wait');
   const accepted=terminal.line(input.run,input.id,'λ雪🙂');reply(accepted);
   assert((await wait(x=>x.type==='done',0,true)).result.value==='λ雪🙂','Fresh reply mismatch');
   const mark=events.length;worker.postMessage({...run,step:false});
   const next=(await wait(x=>x.type==='io-event'&&x.event.kind==='read',mark)).event;
   assert(next.run!==input.run,'Run identity reused');reply(accepted);await sleep();
   assert(!events.slice(mark).some(x=>x.type==='done'||x.type==='error'),'Previous run reply accepted');
   const fresh=new Terminal(next.run);fresh.handle(next);reply(fresh.line(next.run,next.id,'fresh'));
   assert((await wait(x=>x.type==='done',mark)).result.value==='fresh','Fresh run failed');
  }finally{worker.terminate();}
 }