tricu

tree-session.mjs (1867B)

---

 // Private implementation shared by today's two tree adapters, not a requirement
 // on other backends. Runtime handles and checkpoints never leave this closure.
 import {compiledDefinitions} from '../demo-site/dist/compiler.js';
 export function treeSession(g, root, adapter) {
   let definitions=new Map(), disposed=false;
   const active=()=>{if(disposed)throw new Error('Session disposed');};
   const definition=name=>{const h=definitions.get(name);if(h===undefined)throw new Error('Missing definition');return h;};
   const scoped=fn=>{active();return adapter.scope(fn);};
   return {
     runText(value) {return scoped(()=>adapter.toText(g.app(root,adapter.ofText(value))));},
     compile(source) {
       const next=scoped(({keep})=>{
         const input=adapter.ofText(source,16384);
         const defs=compiledDefinitions(g,g.apply(root,[g.leaf,input]));
         for(const h of defs.values())keep(h);
         return defs;
       });
       for(const h of definitions.values())adapter.release(h);
       definitions=next;
       return [...definitions.keys()];
     },
     inspect(name,args) {return scoped(()=>g.toTernary(g.apply(definition(name),args.map(x=>g.fromTernary(x)))));},
     preview(name,limit) {active();return g.preview(definition(name),limit);},
     // Bounded tree inputs are a harness operation, not source compilation.
     // Worker termination is the deadline for divergent evaluation.
     runTree(program,args) {return scoped(()=>{
       const applied=g.apply(g.fromTernary(program),args.map(x=>g.fromTernary(x)));
       return g.toTernary(g.force(applied,0x7fffffffffffffffn));
     });},
     collect() {active();adapter.collect([root,...definitions.values()]);},
     stats() {active();return adapter.stats();},
     dispose() {if(disposed)return;disposed=true;definitions.clear();try{adapter.dispose();}finally{g=undefined;adapter=undefined;}},
   };
 }