tricu

io-lifecycle-probe.mjs (4361B)

---

 // Lifecycle building blocks with a real DOM read/provider and native pure work.
 // This does NOT execute a v2 language program or bypass the production v2 gate.
 export async function run(_control,backend){
  const assert=(value,message)=>{if(!value)throw Error(message);};
  const base=new URL('../',document.querySelector('script[type=module][src]').src);
  const {ioResources:{lifecycle},ioHostWork:{HostWork},runtimeSession}=await import(new URL('dist/probe-api.js',base));
  const session=await runtimeSession.createRuntimeSession(backend,false),checks=[];
  const {tasks,resources}=lifecycle(1n,'owner-stopped','cycle',[null,null,null]),work=new HostWork(tasks);
  const input=document.createElement('input');input.id='lifecycle-test-input';document.body.append(input);
  const original=resources.publish(resources.beginAcquire(0),'reader',input);
  const {task:read,handles}=resources.spawn(0,true,true,[original]),other=tasks.spawn(0,true,false);
  let stale=false;try{resources.lookup(0,original);}catch(error){stale=error.message==='stale-handle';}assert(stale,'old alias survived transfer');
  let acknowledge,aborts=0,events=0,signal;
  const cleanup=new Promise(resolve=>{acknowledge=resolve;});
  const listener=()=>{events++;};input.addEventListener('input',listener);
  const release=async id=>{work.release(id,()=>resources.releaseScope(id,r=>r.backend.remove(),e=>e,'cleanup-failed'));await work.wait();const reply=work.take();assert(reply?.outcome.ok,'release failed');return tasks.settle(id,reply.outcome.value);};
  const finish=async id=>{tasks.bodyDone(id,{kind:'completed',value:null});assert(tasks.beginRelease(id),'release blocked');return release(id);};
  try{
   const fixture=(await(await fetch('/runtime-fixtures.json')).json())['pure-number'];
   await session.load(new Uint8Array(fixture.bytes),fixture.hash);
   work.start(read.key,async abort=>{
    signal=abort;const lease=resources.beginLease(read.key,handles[0],'reader','read');
    try{await new Promise(resolve=>abort.addEventListener('abort',()=>{aborts++;input.removeEventListener('input',listener);resolve();},{once:true}));
    await cleanup;return 'late read value';}finally{resources.endLease(lease.token);}
   });
   const forbidden=()=>{throw Error('pure work invoked IO hook');};
   work.start(other.key,()=>session.run('root',[],'number','pure',{before:forbidden,after:forbidden,read:forbidden,write:forbidden,running:forbidden}));
   await work.wait();const reply=work.take();assert(reply.outcome.ok&&reply.outcome.value.value==='42','native sibling result');await finish(other.key);
   assert(!signal.aborted&&tasks.state(read.key).hostCalls===1,'read was detached');
   input.dispatchEvent(new Event('input'));assert(events===1,'listener not live');
   checks.push('pending DOM read does not block sibling native pure evaluation');
   tasks.cancel(0,read,'cancel read');work.cancelStopped();work.cancelStopped();
   tasks.bodyDone(read.key,{kind:'completed',value:null});
   assert(aborts===1&&signal.aborted,'abort delivered more than once');
   input.dispatchEvent(new Event('input'));assert(events===1,'cancelled listener still active');
   assert(!tasks.beginRelease(read.key)&&input.isConnected,'cancellation request was treated as completion');
   const wait=work.wait();acknowledge();await wait;
   assert(input.isConnected&&work.take()===null,'resource closed before scope release or late reply escaped');
   assert(resources.counts.leases===0,'read lease survived acknowledgement');
   assert(tasks.beginRelease(read.key),'acknowledged read did not release');await release(read.key);
   assert(!input.isConnected,'owned DOM resource escaped physical release');
   tasks.claimJoin(0,read);assert(tasks.pollJoin(0).kind==='cancelled','cancelled join outcome');await finish(0);
   assert(tasks.counts.scopes===0&&tasks.counts.tasks===0&&tasks.counts.hosts===0,'lifecycle retained history');
   assert(work.counts.pending===0&&work.counts.replies===0,'host work retained history');
   assert(resources.counts.resources===0&&resources.counts.leases===0&&resources.counts.admissions===0,'registry retained history');
   checks.push('transferred alias invalidation; leased DOM read; one abort; physical acknowledgement and resource release before cancelled join');
  }finally{acknowledge?.();input.removeEventListener('input',listener);input.remove();session.dispose();}
  return {backend,checks};
 }