tricu

io-v2-core-probe.mjs (3137B)

---

 // Executes bare computation trees privately on native evaluators. Production IO
 // envelopes and terminal providers remain gated; no JS evaluator substitution.
 export async function run(_control,backend){
  const base=new URL('../',document.querySelector('script[type=module][src]').src);
  const fixtures=await(await fetch('/zig-negative.json')).json(),checks=[];
  let execute,dispose;
  if(backend==='haskell-wasm'){
   const {CompilerWorker}=await import(new URL('runtime/haskell/client.mjs',base));
   const client=new CompilerWorker();dispose=()=>client.dispose();await client.request({type:'init',compiler:false});
   execute=async fixture=>{await client.request({type:'load',bytes:new Uint8Array(fixture.bytes).buffer,hash:fixture.hash});return JSON.parse((await client.request({type:'io-v2-core',name:'root',arguments:[]})).text);};
  }else{
   const {WasmRuntime}=await import('/io-v2-runtime.mjs'),{ioV2Private}=await import(new URL('dist/zig-helpers.js',base));
   const g=await WasmRuntime.create(new Uint8Array(await(await fetch(new URL('runtime/zig/arboricx.wasm',base))).arrayBuffer()));
   dispose=()=>g.dispose();let run=0n;
   await g.scopeAsync(async()=>{
    const kept=g.stem(g.leaf),retired=g.stem(g.leaf),owned=g.stats().owned;
    let rejected=false;try{g.sweepScope([kept,-1n]);}catch(error){rejected=error.message==='Stale interpreter root';}
    if(!rejected||g.stats().owned!==owned)throw Error('Invalid sweep partially retired handles');
    g.sweepScope([kept,g.leaf]);
    if(g.observe(kept).node.kind!=='stem')throw Error('Live sweep root lost');
    rejected=false;try{g.observe(retired);}catch{rejected=true;}
    if(!rejected)throw Error('Retired native alias stayed usable');
   });
   checks.push('invalid root sweep is atomic; retired native handles reject');
   execute=async fixture=>{
    const owned=g.stats().owned;
    const out=await g.scopeAsync(async()=>{
     const action=g.load(new Uint8Array(fixture.bytes),'root');
     const tree=ioV2Private.constructors({leaf:g.leaf,observe:g.observe.bind(g),stem:g.stem.bind(g),fork:g.fork.bind(g),app:g.app.bind(g)});
     return ioV2Private.runPrivate(tree,action,++run,roots=>g.sweepScope(roots));
    });
    if(g.stats().owned!==owned)throw Error('Native owned handle history retained');return out;
   };
  }
  const cases=[['pure','completed'],['bind','completed'],['scope','completed'],['child-0','failed'],['child-1','completed'],['unsupported','completed'],['discard-invalid','completed'],['terminal-2','failed'],['terminal-9','cancelled'],['malformed','failed']];
  try{
   for(const [name,kind]of cases){
    const out=await execute(fixtures['v2-run-'+name]);
    const expected={kind,value:kind==='completed'?'42':null,cleanup:0,tasks:{scopes:0,tasks:0,hosts:0},resources:{resources:0,admissions:0,leases:0},host:{pending:0,replies:0}};
    if(JSON.stringify(out)!==JSON.stringify(expected))throw Error(name+': '+JSON.stringify(out));
    checks.push(name);
   }
   for(let i=0;i<5;i++)await execute(fixtures['v2-run-scope']);
   checks.push('repeated run retirement and reuse; native evaluation with per-turn root sweeps');
  }finally{dispose();}
  return {backend,checks};
 }