tricu

check-browser.mjs (4538B)

---

 // Opt-in dependency-free Chromium CDP check. Run via the pinned Nix shell.
 import assert from 'node:assert/strict';
 import {spawn} from 'node:child_process';
 import {createServer} from 'node:http';
 import {readFile,mkdtemp,rm,writeFile} from 'node:fs/promises';
 import {resolve,extname,sep} from 'node:path';
 import {tmpdir} from 'node:os';
 import {createHash} from 'node:crypto';
 import {gzipSync} from 'node:zlib';
 const [directory,output,chromium='chromium']=process.argv.slice(2),root=resolve(directory);
 const server=createServer(async(req,res)=>{
   try{
     const pathname=decodeURIComponent(new URL(req.url,'http://localhost').pathname);
     const module=pathname.match(/^\/_arboricx\/bundle\/hash\/([0-9a-f]{64})$/);
     const file=module?resolve(root,'parity/modules',module[1]+'.arboricx'):resolve(root,'.'+(pathname==='/'?'/index.html':pathname));
     if(!file.startsWith(root+sep))throw Error('Outside root');
     res.setHeader('Cache-Control','no-store');
     res.setHeader('Content-Type',({'.html':'text/html','.mjs':'text/javascript','.js':'text/javascript','.json':'application/json','.wasm':'application/wasm'})[extname(file)]||'application/octet-stream');
     res.end(await readFile(file));
   }catch{res.writeHead(404);res.end();}
 });
 await new Promise(r=>server.listen(0,'127.0.0.1',r));
 const profile=await mkdtemp(resolve(tmpdir(),'haskell-wasm-browser-'));
 let browser,socket,sequence=0;const pending=new Map(),exceptions=[];
 try{
   browser=spawn(chromium,['--headless','--no-sandbox','--disable-dev-shm-usage','--remote-debugging-port=0',`--user-data-dir=${profile}`,'about:blank'],{stdio:['ignore','ignore','pipe']});
   const endpoint=await new Promise((resolve,reject)=>{
     let log='';const timer=setTimeout(()=>reject(Error('Browser startup timeout: '+log)),20000);
     browser.on('error',e=>{clearTimeout(timer);reject(e);});
     browser.on('exit',code=>{clearTimeout(timer);reject(Error('Browser exited '+code+': '+log));});
     browser.stderr.on('data',b=>{log=(log+b).slice(-16000);const m=log.match(/DevTools listening on (ws:\/\/\S+)/);if(m){clearTimeout(timer);resolve(new URL(m[1]));}});
   });
   const tab=await (await fetch(`http://${endpoint.host}/json/new?${encodeURIComponent('http://127.0.0.1:'+server.address().port+'/')}`,{method:'PUT'})).json();
   socket=new WebSocket(tab.webSocketDebuggerUrl);
   await new Promise((r,j)=>{socket.onopen=r;socket.onerror=j;});
   socket.onmessage=({data})=>{
     const m=JSON.parse(data);
     if(m.id){const p=pending.get(m.id);if(!p)return;pending.delete(m.id);clearTimeout(p.timer);m.error?p.reject(Error(JSON.stringify(m.error))):p.resolve(m.result);}
     else if(m.method==='Runtime.exceptionThrown')exceptions.push(m.params);
   };
   const send=(method,params={})=>new Promise((resolve,reject)=>{
     const id=++sequence,timer=setTimeout(()=>{pending.delete(id);reject(Error('CDP timeout: '+method));},120000);
     pending.set(id,{resolve,reject,timer});socket.send(JSON.stringify({id,method,params}));
   });
   await send('Runtime.enable');
   for(let i=0;i<100;i++){
     const r=await send('Runtime.evaluate',{expression:'typeof window.runProbe'});
     if(r.result.value==='function')break;
     await new Promise(r=>setTimeout(r,100));
   }
   const result=await send('Runtime.evaluate',{expression:'window.runProbe()',awaitPromise:true,returnByValue:true});
   assert.ok(!result.exceptionDetails,JSON.stringify(result.exceptionDetails));
   assert.equal(exceptions.length,0,JSON.stringify(exceptions));
   const report=result.result.value;
   report.package=root;
   report.browser=await send('Browser.getVersion');
   report.versions=await readFile(resolve(root,'versions.txt'),'utf8');
   report.manifest=JSON.parse(await readFile(resolve(root,'data/manifest.json')));
   const bytes=await readFile(resolve(root,'reactor.wasm'));
   report.artifact={bytes:bytes.length,gzipBytes:gzipSync(bytes).length,sha256:createHash('sha256').update(bytes).digest('hex')};
   await writeFile(output,JSON.stringify(report,null,2)+'\n');
   console.log(JSON.stringify({checks:report.checks,parity:report.parity,initialization:report.initialization,termination:report.termination,artifact:report.artifact,memory:report.memory},null,2));
 }finally{
   if(socket)socket.close();
   for(const p of pending.values())clearTimeout(p.timer);
   if(browser&&browser.exitCode===null){const exited=new Promise(r=>browser.once('exit',r));browser.kill('SIGKILL');await exited;}
   await new Promise(r=>server.close(r));
   await rm(profile,{recursive:true,force:true,maxRetries:5,retryDelay:100});
 }