tricu

browser-client.mjs (1890B)

---

 // Single-flight Worker ownership. Termination rejects the active request and
 // discards the entire runtime; no attempt to interrupt/reuse a poisoned RTS.
 export class CompilerWorker {
   constructor(){
     this.worker=new Worker(new URL('./worker.mjs',import.meta.url),{type:'module'});
     this.next=0;this.pending=null;this.disposed=false;
     this.worker.onmessage=({data})=>{
       const pending=this.pending;if(!pending||pending.id!==data.id)return;
       clearTimeout(pending.timer);this.pending=null;
       if(data.ok){
         data.text=new TextDecoder('utf-8',{fatal:true}).decode(data.bytes);
         data.roundtripMs=performance.now()-pending.start;
         pending.resolve(data);
       }else{
         pending.reject(Error(data.error));
         if(data.fatal)this.dispose('Fatal runtime error');
       }
     };
     this.worker.onerror=event=>{event.preventDefault();this.dispose(event.message||'Worker failed');};
   }
   request(message,timeout=null){
     if(this.disposed)return Promise.reject(Error('Disposed Worker'));
     if(this.pending)return Promise.reject(Error('Worker is busy'));
     if(timeout!==null&&timeout!==Infinity&&(!Number.isFinite(timeout)||timeout<=0))return Promise.reject(Error('Invalid request deadline'));
     const id=++this.next,start=performance.now();
     return new Promise((resolve,reject)=>{
       const timer=timeout===null||timeout===Infinity?undefined:setTimeout(()=>this.dispose('Worker deadline exceeded'),timeout);
       this.pending={id,resolve,reject,timer,start};
       try{this.worker.postMessage({...message,id});}
       catch(error){this.dispose('Request transport failed: '+error.message);}
     });
   }
   dispose(reason='Worker terminated'){
     if(this.disposed)return;
     this.disposed=true;this.worker.terminate();
     if(this.pending){clearTimeout(this.pending.timer);this.pending.reject(Error(reason));this.pending=null;}
   }
 }