[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_308":309,"_310":311},"routes/_app.x.$handle.$name",{"_98":97,"_31":43,"_107":88,"_26":108,"_13":14,"_109":-5,"_11":110,"_111":112,"_113":114,"_115":116,"_117":118,"_20":-5,"_119":-5,"_120":-5,"_121":24,"_122":123,"_124":24,"_125":-5,"_126":-5,"_127":128},"routes/_app.x.$handle.$name.branch.$branch.version.$version.diff",{"_11":12,"_13":14,"_15":16,"_17":-5,"_18":-5},"project",{"_41":42,"_31":43,"_36":44,"_45":-5,"_46":24,"_47":48,"_49":48,"_50":51,"_52":-5,"_18":53,"_54":55,"_56":57,"_58":-5,"_59":-5,"_60":61,"_62":63,"_64":65,"_66":67,"_68":69,"_70":-5,"_71":72,"_73":72,"_74":75,"_76":75,"_77":75,"_78":72,"_79":72,"_80":81,"_82":83,"_84":85,"_86":24},"version",23,"changes",[19],"aiChatInfo","userId",{"_20":21,"_22":-7,"_23":24,"_25":24,"_26":27,"_28":27},"file",{"_29":30,"_31":27,"_32":33,"_34":35,"_36":37,"_38":14,"_39":40,"_23":24},"previous","deleted",false,"deletedHere","path","r3r1_selector_compact_probe.ts","latestPath","fileId","39fb79d4-ae3f-11f1-83db-1607ee4eb77e","name","fileType","script","content","import { orderedReadyTop2SqlV1 } from \"https://esm.town/v/mosadek/project-brain-live-v1-durable@3265-main/val_native_executor_prod.ts\";\nimport { orderedReadySql } from \"./candidate.ts\";\nconst clean=(s:string)=>s.split(\" \").join(\"\").split(\"\\n\").join(\"\").split(\"\\t\").join(\"\").split(\"\\r\").join(\"\");\nconst a=clean(orderedReadyTop2SqlV1(\"q\")),b=clean(orderedReadySql(\"q\"));let i=0;while(i{let t:any=input,i:any=init;if(typeof input!==\"string\"&&!(input instanceof URL)){const m=String(input?.method||init?.method||\"GET\"),h=new Headers(),s=input?.headers||init?.headers;if(s?.forEach)s.forEach((v:string,k:string)=>h.set(k,v));else if(s)for(const[k,v]of Object.entries(s))h.set(k,String(v));let b:any=undefined;if(m!==\"GET\"&&m!==\"HEAD\")b=typeof input?.arrayBuffer===\"function\"?new Uint8Array(await input.arrayBuffer()):(input?.body??init?.body);t=String(input?.url||\"\");i={method:m,headers:h,body:b,redirect:\"manual\"}}const r:any=await nf(t,i);if(r?.body==null||typeof r.body.cancel===\"function\")return r;const b=new Uint8Array(await r.arrayBuffer());return new Response(b,{status:r.status,statusText:r.statusText,headers:r.headers})}\nconst db:any=createClient({url:`${API_URL}/v3/sqlite/scoped/`,authToken:Deno.env.get(\"VAL_TOWN_API_KEY\"),fetch:f});\nconst rr:any=await db.execute(\"SELECT job_id,lease_attempt_id,lease_instance_id,lease_owner,transport_lease_generation,rank0_id,rank1_id,rank_snapshot_sha256,created_at FROM r8k2_receipts WHERE job_id='persist0' AND lease_attempt_id='cross-invocation-attempt'\");\nconst lr:any=await db.execute(\"SELECT id,state,lease_owner,lease_instance_id,lease_attempt_id,transport_lease_generation FROM r8k2_queue WHERE id='persist0'\");\nconst receipt=rr.rows?.[0]??null,leader=lr.rows?.[0]??null;const ok=!!receipt&&!!leader&&receipt.rank0_id==='persist0'&&receipt.rank1_id==='persist1'&&receipt.lease_attempt_id==='cross-invocation-attempt'&&leader.lease_attempt_id==='cross-invocation-attempt'&&Number(receipt.transport_lease_generation)===Number(leader.transport_lease_generation);\nconsole.log(JSON.stringify({ok,runtime:{deno:Deno.version.deno},receipt,leader}));if(!ok)Deno.exit(2);\n","label",[143],"73f4c191-c89a-4e37-a477-023b6c824b30",["D",1789172200398],[27],"55e0bbb7-65d6-49ac-af4b-b79fac4774e5","r3r1_binding_probe.ts","267f1b54-ae3f-11f1-8081-1607ee4eb77e",22,["D",1789172184916],1,"import { orderedReadyTop2SqlV1 } from \"https://esm.town/v/mosadek/project-brain-live-v1-durable@3265-main/val_native_executor_prod.ts\";\nimport { orderedReadySql, sha256Text } from \"./candidate.ts\";\nconst urls={executor:\"https://esm.town/v/mosadek/project-brain-live-v1-durable@3265-main/val_native_executor_prod.ts\",worker:\"https://esm.town/v/mosadek/project-brain-live-v1-durable@3265-main/brain_bridge_worker.ts\",kernel:\"https://esm.town/v/mosadek/project-brain-live-v1-durable@3265-main/val_native_kernel_v1.ts\",protocol:\"https://esm.town/v/mosadek/project-brain-live-v1-durable@3265-main/BRAIN_VAL_BRIDGE_PROTOCOL.md\"};\nconst out:any={};\nfor(const [k,u] of Object.entries(urls)){const r=await fetch(u);const t=await r.text();out[k]={status:r.status,bytes:new TextEncoder().encode(t).length,sha256:await sha256Text(t),prefix:t.slice(0,80)}}\nconst norm=(s:string)=>s.replace(/\\s+/g,\" \").trim();\nconst a=orderedReadyTop2SqlV1(\"q\"),b=orderedReadySql(\"q\");\nout.selector={exact:a===b,normalized:norm(a)===norm(b),current_sha256:await sha256Text(a),prior_sha256:await sha256Text(b),current_bytes:new TextEncoder().encode(a).length,prior_bytes:new TextEncoder().encode(b).length};\nconsole.log(JSON.stringify(out));\nconst na=norm(a),nb=norm(b);let di=0;while(dih.set(k,v));else if(s)for(const[k,v]of Object.entries(s))h.set(k,String(v));let b:any=undefined;if(m!==\"GET\"&&m!==\"HEAD\")b=typeof input?.arrayBuffer===\"function\"?new Uint8Array(await input.arrayBuffer()):(input?.body??init?.body);t=String(input?.url||\"\");o={method:m,headers:h,body:b,redirect:\"manual\"}}const r:any=await nf(t,o);if(r?.body==null||typeof r.body.cancel===\"function\")return r;const b=new Uint8Array(await r.arrayBuffer());return new Response(b,{status:r.status,statusText:r.statusText,headers:r.headers})}\nconst db:any=createClient({url:`${API_URL}/v3/sqlite/scoped/`,authToken:Deno.env.get(\"VAL_TOWN_API_KEY\"),fetch:cf});const Q=\"r8k2r_queue\",R=\"r8k2r_receipts\",W=\"worker-r8k2-rebase\";\nconst before:any=await db.execute(`SELECT * FROM ${Q} WHERE id IN ('persist0','persist1') ORDER BY id`);const rr:any=await db.execute(`SELECT * FROM ${R} WHERE job_id='persist0' AND lease_attempt_id='cross-invocation-attempt'`);const rows:any[]=before.rows||[],recs:any[]=rr.rows||[];if(rows.length!==2||recs.length!==1)throw new Error(\"PERSISTED_ROWS_OR_RECEIPT_MISSING\");const leader=rows.find((x:any)=>x.id==='persist0'),follower=rows.find((x:any)=>x.id==='persist1'),receipt=recs[0];if(leader.state!==\"LEASED\"||follower.state!==\"READY\"||leader.lease_attempt_id!==\"cross-invocation-attempt\"||receipt.rank0_id!==\"persist0\"||receipt.rank1_id!==\"persist1\")throw new Error(\"PERSISTED_BINDING_MISMATCH\");\nconst H=\"0\".repeat(64),valid=JSON.stringify({returncode:0,stderr:\"\",stdout:JSON.stringify({computed_head:H,events:7,ok:true,stored_head:H})+\"\\n\"});const fin:any=await finalizeLeaderOptionalPreleaseFollowerV1(db,{qTable:Q,rTable:R,job:{...leader,lease_owner:W},expected:{state:\"COMPLETE\",result_json:valid,error_json:null}});const after:any=await db.execute(`SELECT id,state,result_json FROM ${Q} WHERE id IN ('persist0','persist1') ORDER BY id`);const ar:any[]=after.rows||[];const ok=fin.ok===true&&fin.follower_completed===true&&fin.receipt_reason===\"OK\"&&ar.length===2&&ar.every((x:any)=>x.state===\"COMPLETE\"&&x.result_json===valid);const report={ok,schema:\"R8K2_REBASED_CROSS_INVOCATION_RESTART_V1\",production_version:3056,before:rows,receipt,finish:fin,after:ar};await blob.set(\"evidence/r8k2/rebase3056/CROSS_INVOCATION_V1.json\",JSON.stringify(report));console.log(JSON.stringify(report));if(!ok)Deno.exit(2);\n",[164],"f598ef99-5edd-4810-a267-ac6037fa8f7c","qualification_rebase_3056.ts","c3c5db62-adfb-11f1-bd69-1607ee4eb77e",19,["D",1789143401253],5,"import { API_URL } from \"https://esm.town/v/std/API_URL\";\nimport { blob } from \"https://esm.town/v/std/blob/main.ts\";\nimport { createClient } from \"npm:@libsql/client@0.17.2/web\";\nimport { acquireWithPreleaseRankReceiptV1,finalizeLeaderOptionalPreleaseFollowerV1,orderedReadyTop2SqlV1,classifyValNativeCoalesceResultV1,preleaseReceiptBindingReasonV1,ensurePreleaseRankReceiptTableV1 } from \"https://esm.town/v/mosadek/project-brain-live-v1-durable@3056-main/val_native_executor_prod.ts\";\nimport { orderedReadySql,pureSelectorOrder } from \"./candidate.ts\";\nconst nativeFetch=globalThis.fetch.bind(globalThis);\nasync function compat(input:any,init?:any):Promise{let target:any=input,reqInit:any=init;if(typeof input!==\"string\"&&!(input instanceof URL)){const method=String(input?.method||init?.method||\"GET\"),headers=new Headers(),src=input?.headers||init?.headers;if(src?.forEach)src.forEach((v:string,k:string)=>headers.set(k,v));else if(src)for(const[k,v]of Object.entries(src))headers.set(k,String(v));let body:any=undefined;if(method!==\"GET\"&&method!==\"HEAD\")body=typeof input?.arrayBuffer===\"function\"?new Uint8Array(await input.arrayBuffer()):(input?.body??init?.body);target=String(input?.url||\"\");if(!target)throw new Error(\"URL_REQUIRED\");reqInit={method,headers,body,redirect:\"manual\"}}const r:any=await nativeFetch(target,reqInit);if(r?.body==null||typeof r.body.cancel===\"function\")return r;const b=new Uint8Array(await r.arrayBuffer());return new Response(b,{status:r.status,statusText:r.statusText,headers:r.headers})}\nconst db:any=createClient({url:`${API_URL}/v3/sqlite/scoped/`,authToken:Deno.env.get(\"VAL_TOWN_API_KEY\"),fetch:compat});\nconst Q=\"r8k2r_queue\",R=\"r8k2r_receipts\",W=\"worker-r8k2-rebase\",I=\"instance-r8k2-rebase\";\nawait db.execute(`CREATE TABLE IF NOT EXISTS ${Q}(id TEXT PRIMARY KEY,priority REAL NOT NULL,op TEXT NOT NULL,payload_json TEXT NOT NULL,state TEXT NOT NULL DEFAULT 'READY',lease_owner TEXT,lease_expires_at TEXT,result_json TEXT,error_json TEXT,created_at TEXT NOT NULL,updated_at TEXT NOT NULL,transport_lease_generation INTEGER NOT NULL DEFAULT 0,lease_instance_id TEXT,lease_attempt_id TEXT)`);\nawait ensurePreleaseRankReceiptTableV1(db,R);\nconst checks:any[]=[];function ok(name:string,pass:boolean,detail:any=null){checks.push({name,pass,detail});if(!pass)throw new Error(\"CHECK_FAILED:\"+name+\":\"+JSON.stringify(detail))}\nasync function reset(){await db.batch([{sql:`DELETE FROM ${R}`},{sql:`DELETE FROM ${Q}`}],\"write\")}\nfunction p(cmd:string,args:string[]=[cmd],timeout=60){return JSON.stringify({args,timeout})}\nasync function add(id:string,priority:number,payload:string,created:string){await db.execute({sql:`INSERT INTO ${Q}(id,priority,op,payload_json,state,created_at,updated_at) VALUES(?,?,'brain',?,'READY',?,?)`,args:[id,priority,payload,created,created]})}\nconst H=\"0\".repeat(64),t0=\"2026-09-11 15:00:00\";\nconst valChain=JSON.stringify({returncode:0,stderr:\"\",stdout:JSON.stringify({computed_head:H,events:7,ok:true,stored_head:H})+\"\\n\"});\nconst valGraph=JSON.stringify({returncode:0,stderr:\"\",stdout:JSON.stringify({claims:8,ok:true,problems:[]})+\"\\n\"});\nok(\"classifier-chain\",classifyValNativeCoalesceResultV1(valChain)===\"verify-chain\");\nok(\"classifier-graph\",classifyValNativeCoalesceResultV1(valGraph)===\"verify-claim-graph\");\nok(\"classifier-status-rejected\",classifyValNativeCoalesceResultV1(JSON.stringify({returncode:0,stderr:\"\",stdout:'{\"ok\":true}'}))===null);\nconst prodSql=orderedReadyTop2SqlV1(Q),candSql=orderedReadySql(Q),norm=(s:string)=>s.replace(/\\s+/g,\"\");\nok(\"selector-token-equivalence\",norm(prodSql)===norm(candSql),{prod:norm(prodSql),candidate:norm(candSql)});\nok(\"shape-recovery-first\",prodSql.includes(\"recover-stale\")&&prodSql.indexOf(\"recover-stale\")=1&&q.timeout<=120}\nfunction exactRecover(row:any){const q=parsePayload(row);return row.op===\"brain\"&&q&&Object.keys(q).sort().join(\",\")===\"args,timeout\"&&Array.isArray(q.args)&&q.args.length===1&&q.args[0]===\"recover-stale\"&&Number.isInteger(q.timeout)&&q.timeout>=1&&q.timeout<=120}\nfunction validMutationCommand(row:any,cmd:string){const q=parsePayload(row);return row.op===\"brain\"&&q&&Array.isArray(q.args)&&q.args[0]===cmd&&Number.isInteger(q.timeout)&&q.timeout>=1&&q.timeout<=120&&Object.keys(q).sort().join(\",\")===\"args,timeout\"}\nfunction mulberry32(a:number){return()=>{a|=0;a=a+0x6D2B79F5|0;let t=Math.imul(a^a>>>15,1|a);t=t+Math.imul(t^t>>>7,61|t)^t;return((t^t>>>14)>>>0)/4294967296}}\nconst rnd=mulberry32(0x9e3779b9),commands=[\"status\",\"verify-chain\",\"verify-claim-graph\",\"register-agent\",\"claim\",\"commit\",\"ensure-task\",\"renew-lease\",\"recover-stale\",\"other\"];\nfunction desc(r:any,rows:any[],idx:number,nowMs:number){let q:any=null;try{q=JSON.parse(r.payload_json)}catch{}const c=q?.args?.[0]||\"\",closed=q&&Object.keys(q).sort().join(\",\")===\"args,timeout\"&&Number.isInteger(q.timeout)&&q.timeout>=1&&q.timeout<=120,read=closed&&q.args?.length===1&&[\"status\",\"verify-chain\",\"verify-claim-graph\"].includes(c),boot=read||[\"register-agent\",\"claim\"].includes(c),recover=closed&&q.args?.length===1&&c===\"recover-stale\",older=boot&&rows.some((x:any,j:number)=>{let z:any;try{z=JSON.parse(x.payload_json)}catch{return false}return x.state===\"READY\"&&x.op===\"brain\"&&z?.args?.[0]===\"commit\"&&Object.keys(z).sort().join(\",\")===\"args,timeout\"&&Number.isInteger(z.timeout)&&z.timeout>=1&&z.timeout<=120&&(x.created_at=15,pair=c===\"claim\"&&q?.args?.[1]===\"--agent\"&&rows.some((x:any)=>{try{const z=JSON.parse(x.payload_json);return x.state===\"READY\"&&z.args?.[0]===\"register-agent\"&&z.args?.[1]===q.args?.[2]&&x.created_at===r.created_at}catch{return false}}),co=c===\"status\"?0:c===\"verify-chain\"?1:c===\"verify-claim-graph\"?2:c===\"register-agent\"?3:c===\"claim\"?4:5;return [recover?0:1,older?1:0,mission?0:1,boot?0:1,pair?1:0,-Math.min(r.priority,1e9),r.created_at,co,idx+1,r.id]}\nfunction oracle(rows:any[],nowMs:number){const ready=rows.filter((r:any)=>r.state===\"READY\");const indexed=ready.map((r:any)=>({r,idx:rows.indexOf(r),k:desc(r,rows,rows.indexOf(r),nowMs)}));indexed.sort((a:any,b:any)=>{for(let i=0;ib.k[i])return 1}return 0});return indexed.map((x:any)=>x.r.id)}\nlet parity=0;for(let n=0;n<5000;n++){const nowMs=Date.UTC(2026,8,11,16,0,0),count=2+Math.floor(rnd()*7),rows:any[]=[];for(let i=0;ix.state===\"READY\"&&Number(x.transport_lease_generation)===0)&&Number(rbr.rows[0].n)===0,{rows:rbq.rows,receipts:rbr.rows[0]});\nconst acq:any=await acquireWithPreleaseRankReceiptV1(db,{qTable:Q,rTable:R,worker:W,instance:I,attempt:\"attempt-a\"});ok(\"remote-rank0-rank1\",acq.kind===\"leased\"&&acq.rank0===\"rb0\"&&acq.rank1===\"rb1\",acq);const fin:any=await finalizeLeaderOptionalPreleaseFollowerV1(db,{qTable:Q,rTable:R,job:{...acq.job,lease_owner:W},expected:{state:\"COMPLETE\",result_json:valChain,error_json:null}});ok(\"remote-valid-follower\",fin.ok&&fin.follower_completed&&fin.command===\"verify-chain\",fin);\nawait reset();await add(\"m0\",100,p(\"verify-claim-graph\"),t0);await add(\"m1\",100,p(\"verify-claim-graph\"),\"2026-09-11 15:00:01\");const ma:any=await acquireWithPreleaseRankReceiptV1(db,{qTable:Q,rTable:R,worker:W,instance:I,attempt:\"attempt-m\"});await db.execute({sql:`DELETE FROM ${R} WHERE job_id=?`,args:[ma.rank0]});const mf:any=await finalizeLeaderOptionalPreleaseFollowerV1(db,{qTable:Q,rTable:R,job:{...ma.job,lease_owner:W},expected:{state:\"COMPLETE\",result_json:valGraph,error_json:null}});const mstate:any=await db.execute(`SELECT id,state FROM ${Q} ORDER BY id`);ok(\"remote-missing-receipt-leader-only\",mf.ok&&mf.receipt_reason===\"PRELEASE_RECEIPT_MISSING\"&&!mf.follower_completed&&mstate.rows[0].state===\"COMPLETE\"&&mstate.rows[1].state===\"READY\",{mf,rows:mstate.rows});\nawait reset();await add(\"s0\",100,p(\"verify-chain\"),t0);const sa:any=await acquireWithPreleaseRankReceiptV1(db,{qTable:Q,rTable:R,worker:W,instance:I,attempt:\"attempt-old\"});await db.execute({sql:`UPDATE ${Q} SET lease_attempt_id='attempt-new',transport_lease_generation=transport_lease_generation+1 WHERE id=?`,args:[sa.rank0]});const sf:any=await finalizeLeaderOptionalPreleaseFollowerV1(db,{qTable:Q,rTable:R,job:{...sa.job,lease_owner:W},expected:{state:\"COMPLETE\",result_json:valChain,error_json:null}});const sr:any=await db.execute({sql:`SELECT state FROM ${Q} WHERE id=?`,args:[sa.rank0]});ok(\"remote-stale-aba-reject\",sf.ok===false&&sr.rows[0].state===\"LEASED\",sf);\nawait reset();for(let i=0;i<4;i++)await add(\"c\"+i,100-i,p(\"verify-chain\"),`2026-09-11 15:00:0${i}`);const contenders=await Promise.all(Array.from({length:6},async(_,i)=>{try{return await acquireWithPreleaseRankReceiptV1(db,{qTable:Q,rTable:R,worker:W,instance:I,attempt:\"conc-\"+i})}catch(e){return {kind:\"error\",error:String(e)}}}));const cq:any=await db.execute(`SELECT COUNT(*) n FROM ${Q} WHERE state='LEASED'`),cr:any=await db.execute(`SELECT COUNT(*) n FROM ${R}`);ok(\"remote-concurrent-single-flight\",Number(cq.rows[0].n)===1&&Number(cr.rows[0].n)===1&&contenders.filter((x:any)=>x.kind===\"leased\").length===1,{contenders,leased:cq.rows[0].n,receipts:cr.rows[0].n});const second:any=await acquireWithPreleaseRankReceiptV1(db,{qTable:Q,rTable:R,worker:W,instance:I,attempt:\"after-winner\"});ok(\"remote-same-worker-single-flight\",second.kind===\"busy\",second);\nawait reset();await add(\"persist0\",100,p(\"verify-chain\"),t0);await add(\"persist1\",100,p(\"verify-chain\"),\"2026-09-11 15:00:01\");const pa:any=await acquireWithPreleaseRankReceiptV1(db,{qTable:Q,rTable:R,worker:W,instance:I,attempt:\"cross-invocation-attempt\"});ok(\"cross-invocation-seed\",pa.kind===\"leased\"&&!!pa.rank_snapshot_sha256,pa);\nconst summary={ok:checks.every(x=>x.pass),schema:\"R8K2_REBASED_PRODUCTION_EXPORT_QUALIFICATION_V1\",production_version:3056,production_gate_expected_disabled:true,runtime:{deno:Deno.version.deno,v8:Deno.version.v8,typescript:Deno.version.typescript},libsql:\"@libsql/client@0.17.2/web\",checks,semantic:{passed:sem,total:20},scheduler_shape:{passed:3,total:3},scheduler_parity:{passed:parity,total:5000},selector_equivalent_to_prior_qualified_candidate:norm(prodSql)===norm(candSql),cross_invocation_seed:{job_id:pa.rank0,attempt:\"cross-invocation-attempt\",generation:Number(pa.job.transport_lease_generation),rank1:pa.rank1,rank_snapshot_sha256:pa.rank_snapshot_sha256}};\nawait blob.set(\"evidence/r8k2/rebase3056/REPORT_V1.json\",JSON.stringify(summary));\nconsole.log(JSON.stringify(summary));if(!summary.ok)Deno.exit(2);\n",[171],"f01b1196-3171-488f-a875-b2634707f2f9","qualification.ts","025d34ee-adfa-11f1-be58-1607ee4eb77e",["D",1789142481337],"import { API_URL } from \"https://esm.town/v/std/API_URL\";\nimport { createClient } from \"npm:@libsql/client@0.17.2/web\";\nimport { acquireWithDurableReceipt,ensureShadowSchema,finalizeLeaderOptionalFollower,orderedReadySql,pureSelectorOrder,receiptBindingDecision,classifyValidCoalesceResult,sha256Text,PRIORITY_CAP } from \"./candidate.ts\";\nconst nativeFetch=globalThis.fetch.bind(globalThis);\nasync function compat(input:any,init?:any):Promise{let target:any=input,reqInit:any=init;if(typeof input!==\"string\"&&!(input instanceof URL)){const method=String(input?.method||init?.method||\"GET\"),headers=new Headers(),src=input?.headers||init?.headers;if(src?.forEach)src.forEach((v:string,k:string)=>headers.set(k,v));else if(src)for(const[k,v]of Object.entries(src))headers.set(k,String(v));let body:any=undefined;if(method!==\"GET\"&&method!==\"HEAD\")body=typeof input?.arrayBuffer===\"function\"?new Uint8Array(await input.arrayBuffer()):(input?.body??init?.body);target=String(input?.url||\"\");if(!target)throw new Error(\"URL_REQUIRED\");reqInit={method,headers,body,redirect:\"manual\"}}const r:any=await nativeFetch(target,reqInit);if(r?.body==null||typeof r.body.cancel===\"function\")return r;const b=new Uint8Array(await r.arrayBuffer());return new Response(b,{status:r.status,statusText:r.statusText,headers:r.headers})}\nconst db:any=createClient({url:`${API_URL}/v3/sqlite/scoped/`,authToken:Deno.env.get(\"VAL_TOWN_API_KEY\"),fetch:compat});\nconst Q=\"r8k2_queue\",R=\"r8k2_receipts\",W=\"worker-r8k2\",I=\"instance-r8k2\";\nawait ensureShadowSchema(db,Q,R);\nconst checks:any[]=[];function ok(name:string,pass:boolean,detail:any=null){checks.push({name,pass,detail});if(!pass)throw new Error(\"CHECK_FAILED:\"+name+\":\"+JSON.stringify(detail))}\nasync function reset(){await db.batch([{sql:`DELETE FROM ${R}`},{sql:`DELETE FROM ${Q}`}],\"write\")}\nfunction p(cmd:string,args:string[]=[cmd],timeout=60){return JSON.stringify({args,timeout})}\nasync function add(id:string,priority:number,payload:string,created:string){await db.execute({sql:`INSERT INTO ${Q}(id,priority,op,payload_json,state,created_at,updated_at) VALUES(?,?,'brain',?,'READY',?,?)`,args:[id,priority,payload,created,created]})}\nconst H=\"0\".repeat(64);const validChain=JSON.stringify({returncode:0,stdout:JSON.stringify({computed_head:H,events:7,ok:true,stored_head:H})+\"\\n\",stderr:\"\",stdout_truncated:false,stderr_truncated:false});\nconst validGraph=JSON.stringify({returncode:0,stdout:JSON.stringify({claims:8,ok:true,problems:[]})+\"\\n\",stderr:\"\",stdout_truncated:false,stderr_truncated:false});\n\n// Exact current classifier semantics.\nok(\"classifier-chain\",classifyValidCoalesceResult(validChain)===\"verify-chain\");ok(\"classifier-graph\",classifyValidCoalesceResult(validGraph)===\"verify-claim-graph\");ok(\"classifier-reject-status\",classifyValidCoalesceResult(JSON.stringify({returncode:0,stdout:'{\"ok\":true}',stderr:\"\",stdout_truncated:false,stderr_truncated:false}))===null);\n\n// Three load-bearing selector-shape assertions.\nconst sql=orderedReadySql(Q);ok(\"shape-recovery-first\",sql.includes(\"recover-stale\")&&sql.indexOf(\"recover-stale\")x.state===\"READY\"&&Number(x.transport_lease_generation)===0)&&Number(rbr.rows[0].n)===0,{rows:rbq.rows,receipts:rbr.rows[0]});\n\n// Rank0/rank1 capture and valid follower completion.\nconst acq:any=await acquireWithDurableReceipt(db,{qTable:Q,rTable:R,worker:W,instance:I,attempt:\"attempt-a\"});ok(\"remote-rank0-rank1\",acq.kind===\"leased\"&&acq.rank0===\"rb0\"&&acq.rank1===\"rb1\",acq);\nconst fin:any=await finalizeLeaderOptionalFollower(db,{qTable:Q,rTable:R,leaderId:acq.rank0,worker:W,instance:I,attempt:\"attempt-a\",generation:Number(acq.leader.transport_lease_generation),resultJson:validChain});ok(\"remote-valid-follower\",fin.ok&&fin.leader_completed&&fin.follower_completed&&fin.command===\"verify-chain\",fin);\n\n// Missing receipt never authorizes follower, but ordinary valid leader completion survives.\nawait reset();await add(\"m0\",100,p(\"verify-claim-graph\"),t0);await add(\"m1\",100,p(\"verify-claim-graph\"),\"2026-09-11 15:00:01\");const ma:any=await acquireWithDurableReceipt(db,{qTable:Q,rTable:R,worker:W,instance:I,attempt:\"attempt-m\"});await db.execute({sql:`DELETE FROM ${R} WHERE job_id=?`,args:[ma.rank0]});const mf:any=await finalizeLeaderOptionalFollower(db,{qTable:Q,rTable:R,leaderId:ma.rank0,worker:W,instance:I,attempt:\"attempt-m\",generation:Number(ma.leader.transport_lease_generation),resultJson:validGraph});const mstate:any=await db.execute(`SELECT id,state FROM ${Q} ORDER BY id`);ok(\"remote-missing-receipt-leader-only\",mf.ok&&mf.reason===\"PRELEASE_RECEIPT_MISSING\"&&mf.leader_completed&&!mf.follower_completed&&mstate.rows[0].state===\"COMPLETE\"&&mstate.rows[1].state===\"READY\",{mf,rows:mstate.rows});\n\n// Stale/ABA attempt fails before any terminalization.\nawait reset();await add(\"s0\",100,p(\"verify-chain\"),t0);const sa:any=await acquireWithDurableReceipt(db,{qTable:Q,rTable:R,worker:W,instance:I,attempt:\"attempt-old\"});await db.execute({sql:`UPDATE ${Q} SET lease_attempt_id='attempt-new',transport_lease_generation=transport_lease_generation+1 WHERE id=?`,args:[sa.rank0]});const sf:any=await finalizeLeaderOptionalFollower(db,{qTable:Q,rTable:R,leaderId:sa.rank0,worker:W,instance:I,attempt:\"attempt-old\",generation:Number(sa.leader.transport_lease_generation),resultJson:validChain});const sr:any=await db.execute({sql:`SELECT state FROM ${Q} WHERE id=?`,args:[sa.rank0]});ok(\"remote-stale-aba-reject\",sf.ok===false&&sr.rows[0].state===\"LEASED\",sf);\n\n// Concurrent contenders: one durable winner, all others fail closed/busy/error, never >1 lease or receipt.\nawait reset();for(let i=0;i<4;i++)await add(\"c\"+i,100-i,p(\"verify-chain\"),`2026-09-11 15:00:0${i}`);const contenders=await Promise.all(Array.from({length:6},async(_,i)=>{try{return await acquireWithDurableReceipt(db,{qTable:Q,rTable:R,worker:W,instance:I,attempt:\"conc-\"+i})}catch(e){return {kind:\"error\",error:String(e)}}}));const cq:any=await db.execute(`SELECT COUNT(*) n FROM ${Q} WHERE state='LEASED'`),cr:any=await db.execute(`SELECT COUNT(*) n FROM ${R}`);ok(\"remote-concurrent-single-flight\",Number(cq.rows[0].n)===1&&Number(cr.rows[0].n)===1&&contenders.filter((x:any)=>x.kind===\"leased\").length===1,{contenders,leased:cq.rows[0].n,receipts:cr.rows[0].n});\nconst second:any=await acquireWithDurableReceipt(db,{qTable:Q,rTable:R,worker:W,instance:I,attempt:\"after-winner\"});ok(\"remote-same-worker-single-flight\",second.kind===\"busy\",second);\n\n// Twenty semantic binding vectors, inherited contract but independently rerun in Deno.\nconst baseLeader={id:\"L\",state:\"LEASED\",lease_owner:\"w\",lease_instance_id:\"i\",lease_attempt_id:\"a\",transport_lease_generation:3};const baseReceipt={job_id:\"L\",rank0_id:\"L\",rank1_id:\"F\",lease_owner:\"w\",lease_instance_id:\"i\",lease_attempt_id:\"a\",transport_lease_generation:3};const E={worker:\"w\",instance:\"i\",attempt:\"a\",generation:3};\nconst vectors:any[]=[\n [\"baseline\",baseLeader,baseReceipt,E,\"OK\"],[\"missing\",baseLeader,null,E,\"PRELEASE_RECEIPT_MISSING\"],[\"leader-terminal\",{...baseLeader,state:\"COMPLETE\"},baseReceipt,E,\"LEADER_NOT_CURRENTLY_LEASED\"],[\"wrong-owner\",{...baseLeader,lease_owner:\"x\"},baseReceipt,E,\"CURRENT_ATTEMPT_IDENTITY_MISMATCH\"],[\"wrong-instance\",{...baseLeader,lease_instance_id:\"x\"},baseReceipt,E,\"CURRENT_ATTEMPT_IDENTITY_MISMATCH\"],[\"wrong-attempt\",{...baseLeader,lease_attempt_id:\"x\"},baseReceipt,E,\"CURRENT_ATTEMPT_IDENTITY_MISMATCH\"],[\"wrong-generation\",{...baseLeader,transport_lease_generation:4},baseReceipt,E,\"CURRENT_ATTEMPT_IDENTITY_MISMATCH\"],[\"receipt-job\",baseLeader,{...baseReceipt,job_id:\"X\"},E,\"PRELEASE_RECEIPT_CORRUPT\"],[\"receipt-rank0\",baseLeader,{...baseReceipt,rank0_id:\"X\"},E,\"PRELEASE_RECEIPT_CORRUPT\"],[\"receipt-owner\",baseLeader,{...baseReceipt,lease_owner:\"x\"},E,\"PRELEASE_RECEIPT_STALE_OR_MISBOUND\"],[\"receipt-instance\",baseLeader,{...baseReceipt,lease_instance_id:\"x\"},E,\"PRELEASE_RECEIPT_STALE_OR_MISBOUND\"],[\"receipt-attempt\",baseLeader,{...baseReceipt,lease_attempt_id:\"x\"},E,\"PRELEASE_RECEIPT_STALE_OR_MISBOUND\"],[\"receipt-generation\",baseLeader,{...baseReceipt,transport_lease_generation:4},E,\"PRELEASE_RECEIPT_STALE_OR_MISBOUND\"],[\"expect-owner\",baseLeader,baseReceipt,{...E,worker:\"x\"},\"CURRENT_ATTEMPT_IDENTITY_MISMATCH\"],[\"expect-instance\",baseLeader,baseReceipt,{...E,instance:\"x\"},\"CURRENT_ATTEMPT_IDENTITY_MISMATCH\"],[\"expect-attempt\",baseLeader,baseReceipt,{...E,attempt:\"x\"},\"CURRENT_ATTEMPT_IDENTITY_MISMATCH\"],[\"expect-generation\",baseLeader,baseReceipt,{...E,generation:4},\"CURRENT_ATTEMPT_IDENTITY_MISMATCH\"],[\"rank1-null\",baseLeader,{...baseReceipt,rank1_id:null},E,\"OK\"],[\"extra-receipt-field\",baseLeader,{...baseReceipt,extra:\"ignored\"},E,\"OK\"],[\"extra-leader-field\",{...baseLeader,extra:\"ignored\"},baseReceipt,E,\"OK\"]];\nlet semPass=0;for(const [name,l,r,e,want] of vectors){const got=receiptBindingDecision(l,r,e);if(got===want)semPass++;else checks.push({name:\"semantic-\"+name,pass:false,detail:{got,want}})}ok(\"semantic-20\",semPass===20,{passed:semPass,total:20});\n\n// 5000 deterministic scheduler parity cases: independent comparator oracle vs candidate pure selector.\nfunction mulberry32(a:number){return()=>{a|=0;a=a+0x6D2B79F5|0;let t=Math.imul(a^a>>>15,1|a);t=t+Math.imul(t^t>>>7,61|t)^t;return((t^t>>>14)>>>0)/4294967296}}\nconst rnd=mulberry32(0x9e3779b9),commands=[\"status\",\"verify-chain\",\"verify-claim-graph\",\"register-agent\",\"claim\",\"commit\",\"ensure-task\",\"renew-lease\",\"recover-stale\",\"other\"];\nfunction desc(r:any,rows:any[],idx:number,nowMs:number){let q:any=null;try{q=JSON.parse(r.payload_json)}catch{}const c=q?.args?.[0]||\"\",closed=q&&Object.keys(q).sort().join(\",\")===\"args,timeout\"&&Number.isInteger(q.timeout)&&q.timeout>=1&&q.timeout<=120,read=closed&&q.args?.length===1&&[\"status\",\"verify-chain\",\"verify-claim-graph\"].includes(c),boot=read||[\"register-agent\",\"claim\"].includes(c),recover=closed&&q.args?.length===1&&c===\"recover-stale\",older=boot&&rows.some((x:any,j:number)=>{let z:any;try{z=JSON.parse(x.payload_json)}catch{return false}return x.state===\"READY\"&&x.op===\"brain\"&&z?.args?.[0]===\"commit\"&&Object.keys(z).sort().join(\",\")===\"args,timeout\"&&Number.isInteger(z.timeout)&&z.timeout>=1&&z.timeout<=120&&(x.created_at=15,pair=c===\"claim\"&&q?.args?.[1]===\"--agent\"&&rows.some((x:any)=>{try{const z=JSON.parse(x.payload_json);return x.state===\"READY\"&&z.args?.[0]===\"register-agent\"&&z.args?.[1]===q.args?.[2]&&x.created_at===r.created_at}catch{return false}}),co=c===\"status\"?0:c===\"verify-chain\"?1:c===\"verify-claim-graph\"?2:c===\"register-agent\"?3:c===\"claim\"?4:5;return [recover?0:1,older?1:0,mission?0:1,boot?0:1,pair?1:0,-Math.min(r.priority,1e9),r.created_at,co,idx+1,r.id]}\nfunction oracle(rows:any[],nowMs:number){const ready=rows.filter((r:any)=>r.state===\"READY\");const indexed=ready.map((r:any)=>({r,idx:rows.indexOf(r),k:desc(r,rows,rows.indexOf(r),nowMs)}));indexed.sort((a:any,b:any)=>{for(let i=0;ib.k[i])return 1}return 0});return indexed.map((x:any)=>x.r.id)}\nlet parity=0;for(let n=0;n<5000;n++){const nowMs=Date.UTC(2026,8,11,16,0,0),count=2+Math.floor(rnd()*7),rows:any[]=[];for(let i=0;ix.pass),schema:\"R8K2_DENO_LIBSQL_TRANSACTIONAL_ADAPTER_QUALIFICATION_V1\",runtime:{deno:Deno.version.deno,v8:Deno.version.v8,typescript:Deno.version.typescript},libsql:\"@libsql/client@0.17.2/web\",scoped_url:\"API_URL/v3/sqlite/scoped/\",checks,semantic:{passed:semPass,total:20},scheduler_parity:{passed:parity,total:5000},cross_invocation_seed:{job_id:pa.rank0,attempt:\"cross-invocation-attempt\",generation:Number(pa.leader.transport_lease_generation),rank1:pa.rank1,rank_snapshot_sha256:pa.rank_snapshot_sha256}};\nconsole.log(JSON.stringify(summary));if(!summary.ok)Deno.exit(2);\n",[179],"27f41628-f6ae-4a35-a4c0-d05927683283","probe.ts","82bc9ffe-adf9-11f1-a14c-1607ee4eb77e",2,["D",1789142257676],"import { API_URL } from \"https://esm.town/v/std/API_URL\";\nimport { createClient } from \"npm:@libsql/client@0.17.2/web\";\nconst nativeFetch=globalThis.fetch.bind(globalThis);\nasync function compat(input:any,init?:any):Promise{\n let target:any=input, reqInit:any=init;\n if(typeof input!==\"string\" && !(input instanceof URL)){\n const method=String(input?.method||init?.method||\"GET\");\n const headers=new Headers(); const src=input?.headers||init?.headers;\n if(src?.forEach)src.forEach((v:string,k:string)=>headers.set(k,v));\n else if(src)for(const [k,v] of Object.entries(src))headers.set(k,String(v));\n let body:any=undefined;\n if(method!==\"GET\"&&method!==\"HEAD\") body=typeof input?.arrayBuffer===\"function\"?new Uint8Array(await input.arrayBuffer()):(input?.body??init?.body);\n target=String(input?.url||\"\"); if(!target)throw new Error(\"URL_REQUIRED\");\n reqInit={method,headers,body,redirect:\"manual\"};\n }\n const r:any=await nativeFetch(target,reqInit);\n if(r?.body==null||typeof r.body.cancel===\"function\")return r;\n const b=new Uint8Array(await r.arrayBuffer()); return new Response(b,{status:r.status,statusText:r.statusText,headers:r.headers});\n}\nconst db:any=createClient({url:`${API_URL}/v3/sqlite/scoped/`,authToken:Deno.env.get(\"VAL_TOWN_API_KEY\"),fetch:compat});\nconst T=\"r8k2_probe\";\nawait db.execute(`CREATE TABLE IF NOT EXISTS ${T}(id TEXT PRIMARY KEY,v TEXT NOT NULL)`);\nawait db.execute(`DELETE FROM ${T}`);\nlet rollbackThrown=false;\ntry{\n const tx:any=await db.transaction(\"write\");\n try{await tx.execute({sql:`INSERT INTO ${T}(id,v) VALUES(?,?)`,args:[\"rollback\",\"x\"]}); throw new Error(\"INJECTED\");}\n catch(e){await tx.rollback(); rollbackThrown=String(e).includes(\"INJECTED\");}\n}catch(e){console.log(JSON.stringify({ok:false,phase:\"rollback\",error:String(e)}));Deno.exit(1)}\nconst rb:any=await db.execute(`SELECT COUNT(*) n FROM ${T} WHERE id='rollback'`);\nconst tx:any=await db.transaction(\"write\");\nawait tx.execute({sql:`INSERT INTO ${T}(id,v) VALUES(?,?)`,args:[\"persist\",\"y\"]});\nawait tx.commit();\nconst persisted:any=await db.execute(`SELECT id,v FROM ${T} WHERE id='persist'`);\nconst out={ok:rollbackThrown&&Number(rb.rows?.[0]?.n||0)===0&&persisted.rows?.length===1,runtime:{deno:Deno.version.deno,v8:Deno.version.v8,typescript:Deno.version.typescript},libsql:\"@libsql/client@0.17.2/web\",rollback_zero:Number(rb.rows?.[0]?.n||0)===0,persisted:persisted.rows?.[0]??null};\nconsole.log(JSON.stringify(out));\nif(!out.ok)Deno.exit(2);\n",[185],"84ae5f32-64d3-4db7-8e1a-92ff0b42aa87","main.ts","76f0f0e4-adf9-11f1-8468-1607ee4eb77e",["D",1789142237871],"console.log(JSON.stringify({ok:true,fixture:\"r8k2\"}));\n",[192],"ba8782ef-2b39-4492-af08-af563cbbf80c","hash_sources.ts","1ad18c6e-adfa-11f1-86c0-1607ee4eb77e",8,["D",1789142529414],"async function sha(s:string){const d=await crypto.subtle.digest('SHA-256',new TextEncoder().encode(s));return [...new Uint8Array(d)].map(x=>x.toString(16).padStart(2,'0')).join('')}\nconst out:any={import_meta_url:import.meta.url,files:{}};for(const p of ['./candidate.ts','./qualification.ts','./restart_verify.ts']){try{const u=new URL(p,import.meta.url);const r=await fetch(u);const s=await r.text();out.files[p]={url:String(u),status:r.status,bytes:new TextEncoder().encode(s).length,sha256:await sha(s),prefix:s.slice(0,80)}}catch(e){out.files[p]={error:String(e)}}}console.log(JSON.stringify(out));\n",[198],"5660c9ff-09e1-4136-9354-473b9d744638","hash_prod.ts","26bd97d8-adfb-11f1-bfd6-1607ee4eb77e",13,["D",1789143135212],"const enc=new TextEncoder();\nasync function h(path:string){const url=`https://esm.town/v/mosadek/project-brain-live-v1-durable@3054-main/${path}`;const r=await fetch(url);if(!r.ok)throw new Error(`${r.status} ${url}`);const s=await r.text();const b=enc.encode(s);const d=await crypto.subtle.digest('SHA-256',b);return {path,url,bytes:b.length,sha256:[...new Uint8Array(d)].map(x=>x.toString(16).padStart(2,'0')).join('')};}\nconst paths=['brain_bridge_worker.ts','brain_bridge_readonly_coalesce_admission_v1.ts','brain_bridge_readonly_coalesce_v4.ts','val_native_executor_prod.ts','val_native_kernel_v1.ts','BRAIN_VAL_BRIDGE_PROTOCOL.md'];\nconsole.log(JSON.stringify({version:3054,files:await Promise.all(paths.map(h))}));\n",[205],"76578ea0-571d-421e-826e-87ab7e545317","canonical_hash.ts","2c486c2e-adfa-11f1-959c-1607ee4eb77e",9,["D",1789142542136],"async function sha(s:string){const d=await crypto.subtle.digest('SHA-256',new TextEncoder().encode(s));return [...new Uint8Array(d)].map(x=>x.toString(16).padStart(2,'0')).join('')}\nconst base='https://esm.town/v/mosadek/project-brain-live-v1-durable/';const names=['brain_bridge_worker.ts','brain_bridge_readonly_coalesce_admission_v1.ts','brain_bridge_readonly_coalesce_v4.ts','val_native_executor_prod.ts','val_native_kernel_v1.ts','BRAIN_VAL_BRIDGE_PROTOCOL.md'];const out:any={};for(const n of names){const r=await fetch(base+n);const s=await r.text();out[n]={status:r.status,bytes:new TextEncoder().encode(s).length,sha256:await sha(s),prefix:s.slice(0,50)}}console.log(JSON.stringify(out));\n",[212],"5d7b7826-4854-4116-a826-284faab707fc","candidate.ts","dba1e1ce-adf9-11f1-8179-1607ee4eb77e",3,["D",1789142406837],"export const PRIORITY_CAP=1_000_000_000;\nexport const MAX_JOB_TIMEOUT=120;\nexport const LEASE_SECONDS=180;\nexport const MISSION_FAIRNESS_AGE_SECONDS=15;\nexport const COALESCE_COMMANDS=new Set([\"verify-chain\",\"verify-claim-graph\"]);\n\nfunction safeTable(t:string){if(!/^[A-Za-z_][A-Za-z0-9_]*$/.test(t))throw new Error(\"BAD_TABLE\");return t}\nfunction canon(x:any):string{if(x===null||typeof x!==\"object\")return JSON.stringify(x);if(Array.isArray(x))return \"[\"+x.map(canon).join(\",\")+\"]\";return \"{\"+Object.keys(x).sort().map(k=>JSON.stringify(k)+\":\"+canon(x[k])).join(\",\")+\"}\"}\nexport async function sha256Text(s:string){const d=await crypto.subtle.digest(\"SHA-256\",new TextEncoder().encode(s));return [...new Uint8Array(d)].map(x=>x.toString(16).padStart(2,\"0\")).join(\"\")}\n\nexport function orderedReadySql(table:string){\n table=safeTable(table);\n return `SELECT j.rowid AS queue_rowid,j.* FROM ${table} j\n WHERE j.state='READY'\n AND NOT EXISTS(SELECT 1 FROM ${table} x WHERE x.state='LEASED' AND x.lease_owner=? AND x.lease_expires_at>datetime('now'))\n ORDER BY\n CASE WHEN j.op='brain' AND json_valid(j.payload_json)=1 THEN CASE\n WHEN json_type(j.payload_json,'$.args')='array'\n AND json_array_length(json_extract(j.payload_json,'$.args'))=1\n AND json_extract(j.payload_json,'$.args[0]')='recover-stale'\n AND json_type(j.payload_json,'$.timeout')='integer'\n AND json_extract(j.payload_json,'$.timeout') BETWEEN 1 AND ${MAX_JOB_TIMEOUT}\n AND (SELECT COUNT(*) FROM json_each(j.payload_json))=2 THEN 0 ELSE 1 END ELSE 1 END ASC,\n CASE WHEN j.op='brain' AND json_valid(j.payload_json)=1\n AND json_type(j.payload_json,'$.args')='array'\n AND ((json_array_length(json_extract(j.payload_json,'$.args'))=1\n AND json_extract(j.payload_json,'$.args[0]') IN ('status','verify-chain','verify-claim-graph')\n AND json_type(j.payload_json,'$.timeout')='integer'\n AND json_extract(j.payload_json,'$.timeout') BETWEEN 1 AND ${MAX_JOB_TIMEOUT}\n AND (SELECT COUNT(*) FROM json_each(j.payload_json))=2)\n OR json_extract(j.payload_json,'$.args[0]') IN ('register-agent','claim'))\n AND EXISTS(SELECT 1 FROM ${table} c WHERE c.state='READY' AND c.op='brain' AND json_valid(c.payload_json)=1\n AND json_type(c.payload_json,'$.args')='array' AND json_extract(c.payload_json,'$.args[0]')='commit'\n AND json_type(c.payload_json,'$.timeout')='integer' AND json_extract(c.payload_json,'$.timeout') BETWEEN 1 AND ${MAX_JOB_TIMEOUT}\n AND (SELECT COUNT(*) FROM json_each(c.payload_json))=2\n AND (c.created_at=${MISSION_FAIRNESS_AGE_SECONDS}\n THEN 0 ELSE 1 END ASC,\n CASE WHEN j.op='brain' AND json_valid(j.payload_json)=1 AND json_type(j.payload_json,'$.args')='array'\n AND ((json_array_length(json_extract(j.payload_json,'$.args'))=1\n AND json_extract(j.payload_json,'$.args[0]') IN ('status','verify-chain','verify-claim-graph')\n AND json_type(j.payload_json,'$.timeout')='integer' AND json_extract(j.payload_json,'$.timeout') BETWEEN 1 AND ${MAX_JOB_TIMEOUT}\n AND (SELECT COUNT(*) FROM json_each(j.payload_json))=2)\n OR json_extract(j.payload_json,'$.args[0]') IN ('register-agent','claim'))\n THEN 0 ELSE 1 END ASC,\n CASE WHEN j.op='brain' AND json_valid(j.payload_json)=1 AND json_extract(j.payload_json,'$.args[0]')='claim'\n AND json_extract(j.payload_json,'$.args[1]')='--agent'\n AND EXISTS(SELECT 1 FROM ${table} r WHERE r.state='READY' AND r.op='brain' AND json_valid(r.payload_json)=1\n AND json_extract(r.payload_json,'$.args[0]')='register-agent'\n AND json_extract(r.payload_json,'$.args[1]')=json_extract(j.payload_json,'$.args[2]') AND r.created_at=j.created_at)\n THEN 1 ELSE 0 END ASC,\n CASE WHEN j.priority>${PRIORITY_CAP} THEN ${PRIORITY_CAP} ELSE j.priority END DESC,\n j.created_at,\n CASE WHEN j.op='brain' AND json_valid(j.payload_json)=1 AND json_extract(j.payload_json,'$.args[0]')='status' THEN 0\n WHEN j.op='brain' AND json_valid(j.payload_json)=1 AND json_extract(j.payload_json,'$.args[0]')='verify-chain' THEN 1\n WHEN j.op='brain' AND json_valid(j.payload_json)=1 AND json_extract(j.payload_json,'$.args[0]')='verify-claim-graph' THEN 2\n WHEN j.op='brain' AND json_valid(j.payload_json)=1 AND json_extract(j.payload_json,'$.args[0]')='register-agent' THEN 3\n WHEN j.op='brain' AND json_valid(j.payload_json)=1 AND json_extract(j.payload_json,'$.args[0]')='claim' THEN 4 ELSE 5 END ASC,\n j.rowid,j.id LIMIT 2`;\n}\n\nexport async function ensureShadowSchema(db:any,qTable:string,rTable:string){\n qTable=safeTable(qTable);rTable=safeTable(rTable);\n await db.execute(`CREATE TABLE IF NOT EXISTS ${qTable}(\n id TEXT PRIMARY KEY,priority REAL NOT NULL,op TEXT NOT NULL,payload_json TEXT NOT NULL,state TEXT NOT NULL DEFAULT 'READY',\n lease_owner TEXT,lease_expires_at TEXT,result_json TEXT,error_json TEXT,created_at TEXT NOT NULL,updated_at TEXT NOT NULL,\n transport_lease_generation INTEGER NOT NULL DEFAULT 0,lease_instance_id TEXT,lease_attempt_id TEXT)`);\n await db.execute(`CREATE TABLE IF NOT EXISTS ${rTable}(\n job_id TEXT NOT NULL,lease_attempt_id TEXT NOT NULL,lease_instance_id TEXT NOT NULL,lease_owner TEXT NOT NULL,\n transport_lease_generation INTEGER NOT NULL,rank0_id TEXT NOT NULL,rank1_id TEXT,rank_snapshot_sha256 TEXT NOT NULL,\n created_at TEXT NOT NULL,injection_guard INTEGER NOT NULL DEFAULT 0 CHECK(injection_guard=0),PRIMARY KEY(job_id,lease_attempt_id))`);\n}\n\nexport async function acquireWithDurableReceipt(db:any,opts:{qTable:string,rTable:string,worker:string,instance:string,attempt:string,injectReceiptFailure?:boolean}){\n const q=safeTable(opts.qTable),r=safeTable(opts.rTable);const tx:any=await db.transaction(\"write\");\n try{\n const active:any=await tx.execute(`SELECT id FROM ${q} WHERE state='LEASED' AND lease_expires_at>datetime('now') ORDER BY id LIMIT 2`);\n if((active.rows||[]).length){await tx.rollback();return {kind:\"busy\",active_ids:(active.rows||[]).map((x:any)=>String(x.id))}}\n const ranked:any=await tx.execute({sql:orderedReadySql(q),args:[opts.worker]});const rows:any[]=ranked.rows||[];\n if(!rows.length){await tx.rollback();return {kind:\"empty\"}}\n const leader=rows[0],follower=rows[1]??null;\n const u:any=await tx.execute({sql:`UPDATE ${q} SET state='LEASED',lease_owner=?,lease_expires_at=datetime('now','+${LEASE_SECONDS} seconds'),transport_lease_generation=transport_lease_generation+1,lease_instance_id=?,lease_attempt_id=?,updated_at=datetime('now') WHERE id=? AND state='READY' RETURNING *`,args:[opts.worker,opts.instance,opts.attempt,String(leader.id)]});\n const leased:any=u.rows?.[0];if(!leased)throw new Error(\"LEASE_CAS_FAILED\");\n const snap={rank0:{id:String(leader.id),op:String(leader.op),payload_json:String(leader.payload_json),priority:Number(leader.priority),created_at:String(leader.created_at)},rank1:follower?{id:String(follower.id),op:String(follower.op),payload_json:String(follower.payload_json),priority:Number(follower.priority),created_at:String(follower.created_at)}:null};\n const h=await sha256Text(canon(snap));\n await tx.execute({sql:`INSERT INTO ${r}(job_id,lease_attempt_id,lease_instance_id,lease_owner,transport_lease_generation,rank0_id,rank1_id,rank_snapshot_sha256,created_at,injection_guard) VALUES(?,?,?,?,?,?,?,?,datetime('now'),?)`,args:[String(leased.id),opts.attempt,opts.instance,opts.worker,Number(leased.transport_lease_generation),String(leader.id),follower?String(follower.id):null,h,opts.injectReceiptFailure?1:0]});\n await tx.commit();return {kind:\"leased\",leader:leased,rank0:String(leader.id),rank1:follower?String(follower.id):null,rank_snapshot_sha256:h};\n }catch(e){try{await tx.rollback()}catch{};throw e}\n}\n\nfunction plainObject(v:any){return !!v&&typeof v===\"object\"&&!Array.isArray(v)}\nfunction exactKeys(v:any,keys:string[]){const a=Object.keys(v).sort(),b=[...keys].sort();return a.length===b.length&&a.every((x,i)=>x===b[i])}\nfunction hex64(v:any){return typeof v===\"string\"&&/^[0-9a-f]{64}$/.test(v)}\nexport function classifyValidCoalesceResult(resultJson:string):\"verify-chain\"|\"verify-claim-graph\"|null{\n let r:any;try{r=JSON.parse(resultJson)}catch{return null}\n if(!plainObject(r)||!exactKeys(r,[\"returncode\",\"stdout\",\"stderr\",\"stdout_truncated\",\"stderr_truncated\"]))return null;\n if(r.returncode!==0||typeof r.stdout!==\"string\"||r.stderr!==\"\"||r.stdout_truncated!==false||r.stderr_truncated!==false)return null;\n let out:any;try{out=JSON.parse(r.stdout.trim())}catch{return null}if(!plainObject(out))return null;\n if(exactKeys(out,[\"computed_head\",\"events\",\"ok\",\"stored_head\"])&&out.ok===true&&Number.isInteger(out.events)&&out.events>=0&&hex64(out.stored_head)&&out.stored_head===out.computed_head)return \"verify-chain\";\n if(exactKeys(out,[\"claims\",\"ok\",\"problems\"])&&out.ok===true&&Number.isInteger(out.claims)&&out.claims>=0&&Array.isArray(out.problems)&&out.problems.length===0)return \"verify-claim-graph\";\n return null;\n}\n\nexport function receiptBindingDecision(leader:any,receipt:any,expected:{worker:string,instance:string,attempt:string,generation:number}){\n if(!leader||String(leader.state)!==\"LEASED\")return \"LEADER_NOT_CURRENTLY_LEASED\";\n if(String(leader.lease_owner)!==expected.worker||String(leader.lease_instance_id)!==expected.instance||String(leader.lease_attempt_id)!==expected.attempt||Number(leader.transport_lease_generation)!==expected.generation)return \"CURRENT_ATTEMPT_IDENTITY_MISMATCH\";\n if(!receipt)return \"PRELEASE_RECEIPT_MISSING\";\n if(String(receipt.job_id)!==String(leader.id)||String(receipt.rank0_id)!==String(leader.id))return \"PRELEASE_RECEIPT_CORRUPT\";\n if(String(receipt.lease_owner)!==expected.worker||String(receipt.lease_instance_id)!==expected.instance||String(receipt.lease_attempt_id)!==expected.attempt||Number(receipt.transport_lease_generation)!==expected.generation)return \"PRELEASE_RECEIPT_STALE_OR_MISBOUND\";\n return \"OK\";\n}\n\nexport async function finalizeLeaderOptionalFollower(db:any,opts:{qTable:string,rTable:string,leaderId:string,worker:string,instance:string,attempt:string,generation:number,resultJson:string}){\n const q=safeTable(opts.qTable),r=safeTable(opts.rTable);const tx:any=await db.transaction(\"write\");\n try{\n const lr:any=await tx.execute({sql:`SELECT * FROM ${q} WHERE id=? AND state='LEASED' AND lease_owner=? AND lease_instance_id=? AND lease_attempt_id=? AND transport_lease_generation=? AND lease_expires_at>datetime('now')`,args:[opts.leaderId,opts.worker,opts.instance,opts.attempt,opts.generation]});\n const leader:any=lr.rows?.[0]??null;if(!leader){await tx.rollback();return {ok:false,reason:\"CURRENT_ATTEMPT_IDENTITY_MISMATCH\",leader_completed:false,follower_completed:false}}\n const rr:any=await tx.execute({sql:`SELECT * FROM ${r} WHERE job_id=? AND lease_attempt_id=? ORDER BY created_at`,args:[opts.leaderId,opts.attempt]});const recs:any[]=rr.rows||[];const receipt=recs.length===1?recs[0]:null;\n const receiptReason=recs.length>1?\"AMBIGUOUS_PRELEASE_RECEIPTS\":receiptBindingDecision(leader,receipt,{worker:opts.worker,instance:opts.instance,attempt:opts.attempt,generation:opts.generation});\n let followerId:string|null=null;const command=classifyValidCoalesceResult(opts.resultJson);\n if(receiptReason===\"OK\"&&command&&receipt?.rank1_id){\n const fr:any=await tx.execute({sql:`SELECT * FROM ${q} WHERE id=?`,args:[String(receipt.rank1_id)]});const f:any=fr.rows?.[0]??null;\n if(f&&String(f.state)===\"READY\"&&String(f.op)===String(leader.op)&&String(f.payload_json)===String(leader.payload_json)&&Number(f.priority)===Number(leader.priority))followerId=String(f.id);\n }\n const lu:any=await tx.execute({sql:`UPDATE ${q} SET state='COMPLETE',result_json=?,error_json=NULL,lease_owner=NULL,lease_expires_at=NULL,updated_at=datetime('now') WHERE id=? AND state='LEASED' AND lease_owner=? AND lease_instance_id=? AND lease_attempt_id=? AND transport_lease_generation=? RETURNING id`,args:[opts.resultJson,opts.leaderId,opts.worker,opts.instance,opts.attempt,opts.generation]});\n if(!(lu.rows||[]).length){await tx.rollback();return {ok:false,reason:\"LEADER_RESULT_FENCE_REJECTED\",leader_completed:false,follower_completed:false}}\n let followerCompleted=false;\n if(followerId){const fu:any=await tx.execute({sql:`UPDATE ${q} SET state='COMPLETE',result_json=?,error_json=NULL,updated_at=datetime('now') WHERE id=? AND state='READY' RETURNING id`,args:[opts.resultJson,followerId]});followerCompleted=(fu.rows||[]).length===1}\n await tx.commit();return {ok:true,reason:receiptReason,command,leader_completed:true,follower_completed:followerCompleted,follower_id:followerCompleted?followerId:null};\n }catch(e){try{await tx.rollback()}catch{};throw e}\n}\n\nfunction parsePayload(row:any){try{const q=JSON.parse(String(row.payload_json));return q&&typeof q===\"object\"&&!Array.isArray(q)?q:null}catch{return null}}\nfunction closedRead(row:any){const q=parsePayload(row);return row.op===\"brain\"&&q&&Object.keys(q).sort().join(\",\")===\"args,timeout\"&&Array.isArray(q.args)&&q.args.length===1&&[\"status\",\"verify-chain\",\"verify-claim-graph\"].includes(q.args[0])&&Number.isInteger(q.timeout)&&q.timeout>=1&&q.timeout<=120}\nfunction exactRecover(row:any){const q=parsePayload(row);return row.op===\"brain\"&&q&&Object.keys(q).sort().join(\",\")===\"args,timeout\"&&Array.isArray(q.args)&&q.args.length===1&&q.args[0]===\"recover-stale\"&&Number.isInteger(q.timeout)&&q.timeout>=1&&q.timeout<=120}\nfunction validMutationCommand(row:any,cmd:string){const q=parsePayload(row);return row.op===\"brain\"&&q&&Array.isArray(q.args)&&q.args[0]===cmd&&Number.isInteger(q.timeout)&&q.timeout>=1&&q.timeout<=120&&Object.keys(q).sort().join(\",\")===\"args,timeout\"}\nexport function pureSelectorOrder(rows:any[],worker:string,nowMs:number){\n const ready=rows.filter(r=>r.state===\"READY\");\n const active=rows.some(r=>r.state===\"LEASED\"&&r.lease_owner===worker&&Date.parse(String(r.lease_expires_at).replace(\" \",\"T\")+(/[zZ]|[+-]\\d\\d:\\d\\d$/.test(String(r.lease_expires_at))?\"\":\"Z\"))>nowMs);if(active)return [];\n const rowid=new Map(rows.map((r,i)=>[r.id,i+1]));\n const cmd=(r:any)=>parsePayload(r)?.args?.[0]??\"\";\n const validBoot=(r:any)=>closedRead(r)||[\"register-agent\",\"claim\"].includes(cmd(r));\n const olderCommit=(r:any)=>ready.some(c=>validMutationCommand(c,\"commit\")&&(String(c.created_at)[\"ensure-task\",\"renew-lease\",\"supersede-task-context\",\"migrate-task-invariants\"].includes(cmd(r))&&validMutationCommand(r,cmd(r))&&(nowMs-Date.parse(String(r.created_at).replace(\" \",\"T\")+\"Z\"))/1000>=15;\n const pair=(r:any)=>cmd(r)===\"claim\"&&parsePayload(r)?.args?.[1]===\"--agent\"&&ready.some(x=>cmd(x)===\"register-agent\"&&parsePayload(x)?.args?.[1]===parsePayload(r)?.args?.[2]&&String(x.created_at)===String(r.created_at));\n const corder=(r:any)=>cmd(r)===\"status\"?0:cmd(r)===\"verify-chain\"?1:cmd(r)===\"verify-claim-graph\"?2:cmd(r)===\"register-agent\"?3:cmd(r)===\"claim\"?4:5;\n return [...ready].sort((a,b)=>{\n const ka:any[]=[exactRecover(a)?0:1,(validBoot(a)&&olderCommit(a))?1:0,mission(a)?0:1,validBoot(a)?0:1,pair(a)?1:0,-Math.min(Number(a.priority),PRIORITY_CAP),String(a.created_at),corder(a),Number(rowid.get(a.id)),String(a.id)];\n const kb:any[]=[exactRecover(b)?0:1,(validBoot(b)&&olderCommit(b))?1:0,mission(b)?0:1,validBoot(b)?0:1,pair(b)?1:0,-Math.min(Number(b.priority),PRIORITY_CAP),String(b.created_at),corder(b),Number(rowid.get(b.id)),String(b.id)];\n for(let i=0;ikb[i])return 1}return 0;\n }).map(r=>r.id);\n}\n",[219],"58a25570-ce9b-4610-8e52-f8de833d21fb","rollback","01a0913a-d008-734d-8d0b-cde82abe4fb0",10,["D",1789142945808],"directory",[226],"pulls","branches","forks","envVars",{"_239":61,"_241":61},"connections",{"_239":61,"_240":61},"count","unfilledCount","emptyCount",{"_41":225,"_31":226,"_29":227,"_145":-5,"_39":40,"_38":228,"_147":57,"_36":300,"_13":61,"_32":230,"_34":-5,"_23":24,"_150":-5,"_257":301,"_26":302},{"_41":293,"_31":294,"_29":295,"_145":227,"_39":40,"_38":228,"_147":57,"_36":296,"_13":61,"_32":33,"_34":297,"_23":24,"_150":-5,"_257":298,"_26":299},{"_41":218,"_31":219,"_29":220,"_145":-5,"_39":40,"_38":221,"_147":57,"_36":290,"_13":61,"_32":33,"_34":223,"_23":24,"_150":-5,"_257":291,"_26":292},{"_41":211,"_31":212,"_29":213,"_145":-5,"_39":40,"_38":214,"_147":57,"_36":287,"_13":61,"_32":33,"_34":216,"_23":24,"_150":-5,"_257":288,"_26":289},{"_41":204,"_31":205,"_29":206,"_145":-5,"_39":40,"_38":207,"_147":57,"_36":284,"_13":187,"_32":33,"_34":209,"_23":24,"_150":-5,"_257":285,"_26":286},{"_41":197,"_31":198,"_29":199,"_145":-5,"_39":40,"_38":200,"_147":57,"_36":281,"_13":160,"_32":33,"_34":202,"_23":24,"_150":-5,"_257":282,"_26":283},{"_41":191,"_31":192,"_29":193,"_145":-5,"_39":40,"_38":160,"_147":57,"_36":278,"_13":61,"_32":33,"_34":195,"_23":24,"_150":-5,"_257":279,"_26":280},{"_41":184,"_31":185,"_29":186,"_145":-5,"_39":40,"_38":187,"_147":57,"_36":275,"_13":61,"_32":33,"_34":189,"_23":24,"_150":-5,"_257":276,"_26":277},{"_41":178,"_31":179,"_29":180,"_145":-5,"_39":40,"_38":175,"_147":57,"_36":272,"_13":160,"_32":33,"_34":182,"_23":24,"_150":-5,"_257":273,"_26":274},{"_41":170,"_31":171,"_29":172,"_145":-5,"_39":40,"_38":173,"_147":57,"_36":269,"_13":175,"_32":33,"_34":176,"_23":24,"_150":-5,"_257":270,"_26":271},{"_41":163,"_31":164,"_29":165,"_145":-5,"_39":40,"_38":166,"_147":57,"_36":266,"_13":61,"_32":33,"_34":168,"_23":24,"_150":-5,"_257":267,"_26":268},{"_41":155,"_31":156,"_29":157,"_145":-5,"_39":40,"_38":158,"_147":57,"_36":263,"_13":160,"_32":33,"_34":161,"_23":24,"_150":-5,"_257":264,"_26":265},{"_41":152,"_31":27,"_29":30,"_145":-5,"_39":40,"_38":14,"_147":57,"_36":260,"_13":61,"_32":33,"_34":35,"_23":24,"_150":-5,"_257":261,"_26":262},{"_41":142,"_31":143,"_29":144,"_145":-5,"_39":40,"_38":146,"_147":57,"_36":256,"_13":61,"_32":33,"_34":149,"_23":24,"_150":-5,"_257":258,"_26":259},["D",1789142499725],"children",[],[143],["D",1789172200398],[],[27],["D",1789172184916],[],[156],["D",1789143493940],[],[164],["D",1789143401253],[],[171],["D",1789142481337],[],[179],["D",1789142257676],[],[185],["D",1789142237871],[],[192],["D",1789142529414],[],[198],["D",1789143135212],[],[205],["D",1789142542136],[],[212],["D",1789142406837],[],[219],"126e3cdc-c0ab-4efe-94ad-25de4248a41a","val_native_executor_prod.pre_r8k2.ts","01a0913a-d008-734d-8d0b-d0851beddd49",["D",1789142945808],"import { API_URL } from \"https://esm.town/v/std/API_URL\";\nimport { createClient } from \"npm:@libsql/client@0.17.2/web\";\nconst hranaNativeFetch = globalThis.fetch.bind(globalThis);\nasync function hranaCompatFetch(input:any, init?:any):Promise{\n let target:any=input;\n let reqInit:any=init;\n if(typeof input!==\"string\" && !(input instanceof URL)){\n const method=String(input?.method||init?.method||\"GET\");\n const headers=new Headers();\n const src=input?.headers||init?.headers;\n if(src?.forEach) src.forEach((v:string,k:string)=>headers.set(k,v));\n else if(src) for(const [k,v] of Object.entries(src)) headers.set(k,String(v));\n let body:any=undefined;\n if(method!==\"GET\" && method!==\"HEAD\"){\n if(typeof input?.arrayBuffer===\"function\") body=new Uint8Array(await input.arrayBuffer());\n else body=input?.body??init?.body;\n }\n target=String(input?.url||\"\");\n if(!target) throw new Error(\"HRANA_REQUEST_URL_REQUIRED\");\n reqInit={method,headers,body,redirect:\"manual\"};\n }\n const r:any=await hranaNativeFetch(target,reqInit);\n if(r?.body==null||typeof r.body.cancel===\"function\") return r;\n const bytes=new Uint8Array(await r.arrayBuffer());\n return new Response(bytes,{status:r.status,statusText:r.statusText,headers:r.headers});\n}\nconst sqlite=createClient({\n url:`${API_URL}/v3/sqlite/scoped/`,\n authToken:Deno.env.get(\"VAL_TOWN_API_KEY\"),\n fetch:hranaCompatFetch,\n});\nimport { leaseOneSql } from \"./brain_bridge_worker.ts\";\nimport { dispatchBrain, verifyBrainChain, verifyBrainClaimGraph } from \"./val_native_kernel_v1.ts\";\n\nconst JOB_TABLE=\"brain_bridge_jobs\";\nconst AUTH_TABLE=\"brain_control_plane_authority_v1\";\n// A unique module query-string creates an independent worker incarnation inside the\n// same Val runtime. The default preserves the canonical executor identity.\nconst moduleUrl=new URL(import.meta.url);\nconst WORKER=moduleUrl.searchParams.get(\"worker\")||\"project-brain-val-native-v1\";\nconst INSTANCE=moduleUrl.searchParams.get(\"instance\")||\"val-native-epoch2\";\nconst LEASE_SECONDS=180;\nconst MUTATION_RECEIPT_TABLE=\"brainvn_mutation_receipts\";\nconst RUNTIME_TICK_TABLE=\"val_native_executor_runtime_v1\";\nconst RUNTIME_TICK_TTL_SECONDS=300;\nasync function ensureMutationReceiptTable(db:any=sqlite){\n await db.execute(`CREATE TABLE IF NOT EXISTS ${MUTATION_RECEIPT_TABLE}(\n job_id TEXT NOT NULL,\n lease_attempt_id TEXT NOT NULL,\n lease_instance_id TEXT NOT NULL,\n lease_owner TEXT NOT NULL,\n transport_lease_generation INTEGER NOT NULL,\n authority_epoch INTEGER NOT NULL,\n command TEXT NOT NULL,\n payload_sha256 TEXT NOT NULL,\n committed_generation INTEGER NOT NULL,\n event_head_hash TEXT NOT NULL,\n result_json TEXT NOT NULL,\n committed_at TEXT NOT NULL,\n PRIMARY KEY(job_id,lease_attempt_id)\n )`);\n}\n\nfunction legacyEnvelope(v:any){return JSON.stringify({returncode:0,stderr:\"\",stdout:JSON.stringify(v)+\"\\n\"})}\nasync function sha256Text(s:string){\n const d=await crypto.subtle.digest(\"SHA-256\",new TextEncoder().encode(s));\n return [...new Uint8Array(d)].map(x=>x.toString(16).padStart(2,\"0\")).join(\"\");\n}\nasync function authority(){\n const r:any=await sqlite.execute(`SELECT epoch,writer,source_generation,source_head,mode,prepared_at,updated_at FROM ${AUTH_TABLE} WHERE id=1`);\n return r.rows?.[0]??null;\n}\nconst RESULT_FINALIZATION_HELPER_V1_SHA256=\"b82e4f00c3f7b3eb721871e780d0f7c43180e32516b9a5c87112a956e550677f\";\nconst RESULT_FINALIZATION_HELPER_V1_SOURCE=String.raw`// RESULT_FINALIZATION_EXACT_ATTEMPT_RECONCILIATION_V1\n// Candidate-only pure helper. It never dispatches/re-dispatches a Brain command.\n// Production integration supplies narrowly-scoped queue/authority/receipt operations.\n\nexport const READ_ONLY_COMMANDS_V1 = new Set([\"status\",\"verify-chain\",\"verify-claim-graph\"]);\n\nexport function canonV1(x) {\n if (x === null || typeof x !== \"object\") return JSON.stringify(x);\n if (Array.isArray(x)) return \"[\" + x.map(canonV1).join(\",\") + \"]\";\n return \"{\" + Object.keys(x).sort().map(k => JSON.stringify(k) + \":\" + canonV1(x[k])).join(\",\") + \"}\";\n}\n\nexport function legacyEnvelopeV1(v) {\n return JSON.stringify({returncode:0, stderr:\"\", stdout:JSON.stringify(v) + \"\\n\"});\n}\n\nexport async function sha256TextV1(s) {\n const d = await crypto.subtle.digest(\"SHA-256\", new TextEncoder().encode(s));\n return [...new Uint8Array(d)].map(x => x.toString(16).padStart(2,\"0\")).join(\"\");\n}\n\nfunction errText(e) {\n return e instanceof Error ? e.message : String(e);\n}\n\nfunction authorityMatches(a, epoch, mode) {\n return !!a &&\n Number(a.epoch) === Number(epoch) &&\n String(a.writer) === \"val_native\" &&\n String(a.mode) === String(mode);\n}\n\nfunction expectedTerminal(dispatchOk, dispatchValue) {\n return dispatchOk\n ? {state:\"COMPLETE\", result_json:legacyEnvelopeV1(dispatchValue), error_json:null}\n : {state:\"FAILED\", result_json:null, error_json:JSON.stringify(dispatchValue)};\n}\n\nfunction sameNullable(a,b) {\n return (a ?? null) === (b ?? null);\n}\n\nfunction exactStaticJobBinding(row, job) {\n return !!row &&\n String(row.id) === String(job.id) &&\n String(row.op) === String(job.op) &&\n String(row.payload_json) === String(job.payload_json) &&\n Number(row.transport_lease_generation) === Number(job.transport_lease_generation);\n}\n\nfunction exactLiveAttempt(row, job) {\n return exactStaticJobBinding(row, job) &&\n String(row.lease_instance_id) === String(job.lease_instance_id) &&\n String(row.lease_attempt_id) === String(job.lease_attempt_id);\n}\n\nfunction exactTerminal(row, job, expected) {\n return exactLiveAttempt(row, job) &&\n String(row.state) === expected.state &&\n sameNullable(row.result_json, expected.result_json) &&\n sameNullable(row.error_json, expected.error_json) &&\n row.lease_owner == null &&\n row.lease_expires_at == null;\n}\n\nfunction leaseUnexpired(row, nowIso) {\n return !!row?.lease_expires_at && String(row.lease_expires_at) > String(nowIso);\n}\n\nfunction isExpiryUnknown(row) {\n if (!row || String(row.state) !== \"FAILED\" || row.result_json != null) return false;\n try {\n const e = JSON.parse(String(row.error_json || \"{}\"));\n return e?.classification === \"TRANSPORT_LEASE_EXPIRED_OUTCOME_UNKNOWN_REQUIRES_CANONICAL_RECONCILIATION\";\n } catch {\n return false;\n }\n}\n\nasync function exactReceipt(receipts, job, expectedEpoch, command, dispatchValue) {\n if (!Array.isArray(receipts) || receipts.length !== 1) return {ok:false, reason:receipts?.length > 1 ? \"AMBIGUOUS_MUTATION_RECEIPTS\" : \"MUTATION_RECEIPT_MISSING\"};\n const r = receipts[0];\n const payloadSha = await sha256TextV1(String(job.payload_json));\n if (String(r.job_id) !== String(job.id)) return {ok:false,reason:\"RECEIPT_JOB_MISMATCH\"};\n if (String(r.lease_attempt_id) !== String(job.lease_attempt_id)) return {ok:false,reason:\"RECEIPT_ATTEMPT_MISMATCH\"};\n if (String(r.lease_instance_id) !== String(job.lease_instance_id)) return {ok:false,reason:\"RECEIPT_INSTANCE_MISMATCH\"};\n if (String(r.lease_owner) !== String(job.lease_owner)) return {ok:false,reason:\"RECEIPT_OWNER_MISMATCH\"};\n if (Number(r.transport_lease_generation) !== Number(job.transport_lease_generation)) return {ok:false,reason:\"RECEIPT_GENERATION_MISMATCH\"};\n if (Number(r.authority_epoch) !== Number(expectedEpoch)) return {ok:false,reason:\"RECEIPT_AUTHORITY_EPOCH_MISMATCH\"};\n if (String(r.command) !== String(command)) return {ok:false,reason:\"RECEIPT_COMMAND_MISMATCH\"};\n if (String(r.payload_sha256) !== payloadSha) return {ok:false,reason:\"RECEIPT_PAYLOAD_MISMATCH\"};\n if (String(r.result_json) !== canonV1(dispatchValue)) return {ok:false,reason:\"RECEIPT_RESULT_MISMATCH\"};\n return {ok:true, receipt:r, payload_sha256:payloadSha};\n}\n\nasync function readOnlyStillFresh(command, preDispatchGeneration, deps) {\n if (!READ_ONLY_COMMANDS_V1.has(command)) return {ok:true};\n if (!Number.isInteger(preDispatchGeneration)) return {ok:false,reason:\"READ_ONLY_PRE_DISPATCH_GENERATION_REQUIRED\"};\n const g = await deps.readCanonicalGeneration();\n if (Number(g) !== Number(preDispatchGeneration)) return {ok:false,reason:\"READ_ONLY_CANONICAL_GENERATION_DRIFT\",expected:preDispatchGeneration,actual:Number(g)};\n return {ok:true};\n}\n\n/**\n * deps contract:\n * - readAuthority()\n * - readJob(id)\n * - readCanonicalGeneration()\n * - finishOncePreservingAttempt(job, expected) // exact attempt UPDATE; at most called twice total: initial + one retry\n * - readMutationReceipts(jobId, attemptId)\n * - finalizeExpiredMutationFromReceipt(job, expected, receipt)\n * - nowIso()\n *\n * No dispatch/re-dispatch function is accepted by this helper.\n */\nexport async function finalizeExactAttemptV1({\n job,\n expectedAuthorityEpoch,\n expectedAuthorityMode,\n command,\n dispatchOk,\n dispatchValue,\n preDispatchGeneration,\n deps,\n}) {\n const expected = expectedTerminal(dispatchOk, dispatchValue);\n const readOnly = READ_ONLY_COMMANDS_V1.has(command);\n const trace = [];\n let finishCalls = 0;\n\n const a0 = await deps.readAuthority();\n if (!authorityMatches(a0, expectedAuthorityEpoch, expectedAuthorityMode)) {\n return {ok:false,reason:\"FINALIZE_AUTHORITY_FENCED_PRE\",trace,finish_calls:finishCalls};\n }\n const fresh0 = await readOnlyStillFresh(command, preDispatchGeneration, deps);\n if (!fresh0.ok) return {...fresh0,trace,finish_calls:finishCalls};\n\n // Normal path. Candidate production finishOnce must preserve lease_instance_id and\n // lease_attempt_id on terminal rows so a client-unknown finish can be read back\n // as the exact attempt rather than merely the same job id.\n try {\n finishCalls++;\n const f = await deps.finishOncePreservingAttempt(job, expected);\n trace.push({phase:\"finish_initial\",returned:f});\n if (f?.ok === true) {\n const rb = await deps.readJob(job.id);\n if (!exactTerminal(rb,job,expected)) return {ok:false,reason:\"FINISH_SUCCESS_READBACK_MISMATCH\",trace,finish_calls:finishCalls};\n return {ok:true,reconciled:false,path:\"INITIAL_FINISH\",trace,finish_calls:finishCalls};\n }\n trace.push({phase:\"finish_initial_nonok\",value:f});\n } catch (e) {\n trace.push({phase:\"finish_initial_throw\",error:errText(e)});\n }\n\n // Outcome-aware reconciliation begins. Re-read authority after the uncertain client outcome.\n const a1 = await deps.readAuthority();\n if (!authorityMatches(a1, expectedAuthorityEpoch, expectedAuthorityMode)) {\n return {ok:false,reason:\"FINALIZE_AUTHORITY_FENCED_RECONCILE\",trace,finish_calls:finishCalls};\n }\n const fresh1 = await readOnlyStillFresh(command, preDispatchGeneration, deps);\n if (!fresh1.ok) return {...fresh1,trace,finish_calls:finishCalls};\n\n let row = await deps.readJob(job.id);\n if (!row || !exactStaticJobBinding(row,job)) {\n return {ok:false,reason:\"QUEUE_JOB_BINDING_MISMATCH\",trace,finish_calls:finishCalls};\n }\n\n // Case A: UPDATE committed but client threw. Terminal readback itself proves completion,\n // but only because candidate finish preserves exact attempt identity.\n if (exactTerminal(row,job,expected)) {\n return {ok:true,reconciled:true,path:\"TERMINAL_EXACT_READBACK\",trace,finish_calls:finishCalls};\n }\n\n // Case B: UPDATE did not commit. Retry the exact finish at most once, only while this\n // exact attempt is still leased and unexpired.\n if (String(row.state) === \"LEASED\" && exactLiveAttempt(row,job) && String(row.lease_owner) === String(job.lease_owner) && leaseUnexpired(row,deps.nowIso())) {\n try {\n finishCalls++;\n const f2 = await deps.finishOncePreservingAttempt(job, expected);\n trace.push({phase:\"finish_retry_once\",returned:f2});\n } catch (e) {\n trace.push({phase:\"finish_retry_once_throw\",error:errText(e)});\n }\n const fresh2 = await readOnlyStillFresh(command, preDispatchGeneration, deps);\n if (!fresh2.ok) return {...fresh2,trace,finish_calls:finishCalls};\n const rb2 = await deps.readJob(job.id);\n if (exactTerminal(rb2,job,expected)) {\n return {ok:true,reconciled:true,path:\"ONE_EXACT_FINISH_RETRY\",trace,finish_calls:finishCalls};\n }\n return {ok:false,reason:\"ONE_FINISH_RETRY_EXHAUSTED\",trace,finish_calls:finishCalls};\n }\n\n // Read-only results may never be resurrected after lease expiry/reassignment, and they\n // may never cross canonical generation drift.\n if (readOnly) {\n return {ok:false,reason:\"READ_ONLY_RESULT_NOT_SAFE_TO_RECONCILE\",trace,finish_calls:finishCalls};\n }\n\n // A mutation receipt is not a license to reinterpret a still-LEASED row from another\n // attempt/instance. Receipt-bound recovery below is only for the exact known\n // expiry-terminalization state, never for a live/reassigned lease.\n if (String(row.state) === \"LEASED\") {\n if (!exactLiveAttempt(row,job)) {\n return {ok:false,reason:\"LIVE_ATTEMPT_IDENTITY_MISMATCH\",trace,finish_calls:finishCalls};\n }\n return {ok:false,reason:\"LEASED_ATTEMPT_EXPIRED_OR_UNSAFE_AFTER_ONE_RETRY\",trace,finish_calls:finishCalls};\n }\n\n // Case C: mutation dispatch is canonically known from the exact bound receipt.\n // This may repair the historical FAILED/OUTCOME_UNKNOWN transport row without\n // re-dispatching the canonical mutation.\n if (dispatchOk !== true) {\n return {ok:false,reason:\"MUTATION_DISPATCH_EXCEPTION_HAS_NO_SAFE_RECEIPT_ASSUMPTION\",trace,finish_calls:finishCalls};\n }\n const receipts = await deps.readMutationReceipts(job.id,job.lease_attempt_id);\n const rr = await exactReceipt(receipts,job,expectedAuthorityEpoch,command,dispatchValue);\n if (!rr.ok) return {...rr,trace,finish_calls:finishCalls};\n\n // Only the exact known expiry terminalization is repairable after expiry. Transport\n // generation equality proves no later lease generation was issued for this job.\n if (!isExpiryUnknown(row) || Number(row.transport_lease_generation) !== Number(job.transport_lease_generation)) {\n return {ok:false,reason:\"EXPIRED_RECEIPT_RECOVERY_ROW_NOT_ELIGIBLE\",trace,finish_calls:finishCalls};\n }\n if (row.lease_owner != null || row.lease_expires_at != null) {\n return {ok:false,reason:\"EXPIRED_RECEIPT_RECOVERY_ROW_STILL_OWNED\",trace,finish_calls:finishCalls};\n }\n // Historical recovery cleared attempt/instance. If present, they must still match.\n if (row.lease_attempt_id != null && String(row.lease_attempt_id) !== String(job.lease_attempt_id)) {\n return {ok:false,reason:\"EXPIRED_RECEIPT_ROW_ATTEMPT_CONFLICT\",trace,finish_calls:finishCalls};\n }\n if (row.lease_instance_id != null && String(row.lease_instance_id) !== String(job.lease_instance_id)) {\n return {ok:false,reason:\"EXPIRED_RECEIPT_ROW_INSTANCE_CONFLICT\",trace,finish_calls:finishCalls};\n }\n\n const rec = await deps.finalizeExpiredMutationFromReceipt(job,expected,rr.receipt);\n trace.push({phase:\"receipt_bound_expiry_recovery\",returned:rec});\n const a2 = await deps.readAuthority();\n if (!authorityMatches(a2, expectedAuthorityEpoch, expectedAuthorityMode)) {\n return {ok:false,reason:\"FINALIZE_AUTHORITY_FENCED_POST_RECEIPT\",trace,finish_calls:finishCalls};\n }\n const rb3 = await deps.readJob(job.id);\n if (!exactTerminal(rb3,job,expected)) {\n return {ok:false,reason:\"RECEIPT_RECOVERY_READBACK_MISMATCH\",trace,finish_calls:finishCalls};\n }\n return {ok:true,reconciled:true,path:\"EXACT_MUTATION_RECEIPT_EXPIRY_RECOVERY\",trace,finish_calls:finishCalls};\n}\n`;\nlet resultFinalizationHelperV1Promise:Promise|null=null;\nasync function resultFinalizationHelperV1(){\n const h=await sha256Text(RESULT_FINALIZATION_HELPER_V1_SOURCE);\n if(h!==RESULT_FINALIZATION_HELPER_V1_SHA256)throw new Error(\"RESULT_FINALIZATION_HELPER_INTEGRITY_MISMATCH\");\n if(!resultFinalizationHelperV1Promise){\n resultFinalizationHelperV1Promise=import(\"data:text/javascript;charset=utf-8,\"+encodeURIComponent(RESULT_FINALIZATION_HELPER_V1_SOURCE));\n }\n return await resultFinalizationHelperV1Promise;\n}\n\nasync function canonicalAnchor(){\n const r:any=await sqlite.execute(\"SELECT generation,event_head_hash FROM brainvn_epoch_meta WHERE id=1\");\n const row:any=r.rows?.[0]??null;\n const g=Number(row?.generation),head=String(row?.event_head_hash??\"\");\n if(!Number.isInteger(g)||g<0||!/^[0-9a-f]{64}$/.test(head))throw new Error(\"CANONICAL_ANCHOR_UNAVAILABLE\");\n return {generation:g,event_head_hash:head};\n}\nasync function canonicalGeneration(){return (await canonicalAnchor()).generation;}\nasync function normalizedFinalizationAuthority(){\n const g:any=await admit();\n if(g?.ok===true)return {epoch:Number(g.epoch),writer:\"val_native\",mode:String(g.mode)};\n const a:any=g?.authority??await authority();\n return {epoch:Number(a?.epoch),writer:String(a?.writer??\"\"),mode:String(a?.mode)===\"PREPARED\"?\"PREPARED_READ_ONLY\":String(a?.mode??\"\")};\n}\n\nasync function emitRuntimeTick(){\n const a:any=await authority();\n if(!a||String(a.writer)!==\"val_native\"||![\"ACTIVE\",\"PREPARED\"].includes(String(a.mode))){\n return {ok:false,emitted:false,reason:\"VAL_NATIVE_NOT_SELECTED\",authority:a??null};\n }\n await sqlite.execute(`CREATE TABLE IF NOT EXISTS ${RUNTIME_TICK_TABLE}(\n id TEXT PRIMARY KEY,\n worker_id TEXT NOT NULL,\n instance_id TEXT NOT NULL,\n authority_epoch INTEGER NOT NULL,\n state TEXT NOT NULL,\n tick_at TEXT NOT NULL,\n expires_at TEXT NOT NULL,\n metadata_json TEXT NOT NULL\n )`);\n const metadata=JSON.stringify({\n classification:\"NONAUTHORITY_EXECUTOR_RUNTIME_TICK\",\n grants_brain_authority:false,\n extends_canonical_lease:false,\n source:\"val_native_executor_prod.drain\"\n });\n await sqlite.execute({\n sql:`INSERT INTO ${RUNTIME_TICK_TABLE}(id,worker_id,instance_id,authority_epoch,state,tick_at,expires_at,metadata_json)\n VALUES('val-native-executor',?,?,?,'RUNNING',datetime('now'),datetime('now','+${RUNTIME_TICK_TTL_SECONDS} seconds'),?)\n ON CONFLICT(id) DO UPDATE SET\n worker_id=excluded.worker_id,\n instance_id=excluded.instance_id,\n authority_epoch=excluded.authority_epoch,\n state='RUNNING',\n tick_at=excluded.tick_at,\n expires_at=excluded.expires_at,\n metadata_json=excluded.metadata_json`,\n args:[WORKER,INSTANCE,Number(a.epoch),metadata]\n });\n return {ok:true,emitted:true,authority_epoch:Number(a.epoch),ttl_seconds:RUNTIME_TICK_TTL_SECONDS};\n}\nasync function admit(){\n const a:any=await authority();\n if(!a)return {ok:false,reason:\"AUTHORITY_UNINITIALIZED\",authority:null};\n if(String(a.writer)!==\"val_native\")return {ok:false,reason:\"WRITER_NOT_CANONICAL\",authority:a};\n const mode=String(a.mode);\n if(mode===\"ACTIVE\")return {ok:true,epoch:Number(a.epoch),mode:\"ACTIVE\",authority:a};\n if(mode===\"PREPARED\")return {ok:true,epoch:Number(a.epoch),mode:\"PREPARED_READ_ONLY\",authority:a};\n return {ok:false,reason:\"AUTHORITY_MODE_NOT_ADMITTED\",authority:a};\n}\nconst ACQUIRE_RECONCILE_ATTEMPTS_R2=3;\ntype LeaseReconcileResultR2=\n | {kind:\"leased\";job:any;epoch:number;mode:string;acquisition_reconciled:true;acquisition_error:string}\n | {kind:\"none\";attempt_id:string}\n | {kind:\"outcome_unknown\";attempt_id:string;errors:string[]};\nexport async function reconcileExactLeaseAttemptR2(\n attempt:string,\n expectedEpoch:number,\n expectedMode:string,\n acquisitionError:unknown,\n):Promise{\n const errors:string[]=[];\n for(let i=0;i=1\n AND lease_expires_at>datetime('now')\n ORDER BY id`,args:[WORKER,INSTANCE,attempt]});\n const rows:any[]=r.rows||[];\n if(rows.length===0)return {kind:\"none\",attempt_id:attempt};\n if(rows.length!==1){\n return {kind:\"outcome_unknown\",attempt_id:attempt,errors:[...errors,`ATTEMPT_CARDINALITY_CONFLICT_${rows.length}`]};\n }\n const job=rows[0];\n if(String(job.lease_instance_id)!==INSTANCE||String(job.lease_attempt_id)!==attempt||Number(job.transport_lease_generation)<1){\n return {kind:\"outcome_unknown\",attempt_id:attempt,errors:[...errors,\"ATTEMPT_IDENTITY_POSTCONDITION_FAILED\"]};\n }\n return {\n kind:\"leased\",\n job,\n epoch:expectedEpoch,\n mode:expectedMode,\n acquisition_reconciled:true,\n acquisition_error:acquisitionError instanceof Error?acquisitionError.message:String(acquisitionError),\n };\n }catch(e){\n errors.push(e instanceof Error?e.message:String(e));\n }\n }\n return {kind:\"outcome_unknown\",attempt_id:attempt,errors};\n}\nasync function recoverExpiredTransport(){\n const tx:any=await (sqlite as any).transaction(\"write\");let done=false;\n try{\n const r:any=await tx.execute(`SELECT id,op,payload_json,lease_owner,lease_instance_id,lease_attempt_id,transport_lease_generation,lease_expires_at\n FROM ${JOB_TABLE} WHERE state='LEASED' AND lease_expires_at IS NOT NULL AND lease_expires_at<=datetime('now') ORDER BY id`);\n const outcomes:any[]=[];\n for(const j of (r.rows||[])){\n const u:any=await tx.execute({sql:`UPDATE ${JOB_TABLE}\n SET state='FAILED',result_json=NULL,\n error_json=json_object(\n 'classification','TRANSPORT_LEASE_EXPIRED_OUTCOME_UNKNOWN_REQUIRES_CANONICAL_RECONCILIATION',\n 'receipt_policy','SIDE_RECEIPTS_DIAGNOSTIC_ONLY_NOT_COMPLETION_AUTHORITY',\n 'retry_policy','RECONCILE_CANONICAL_STATE_THEN_NEW_JOB_ID'\n ),\n lease_owner=NULL,lease_expires_at=NULL,updated_at=datetime('now')\n WHERE id=? AND state='LEASED' AND lease_owner IS ? AND lease_instance_id IS ? AND lease_attempt_id IS ? AND transport_lease_generation=? AND lease_expires_at<=datetime('now')\n RETURNING id`,\n args:[j.id,j.lease_owner,j.lease_instance_id,j.lease_attempt_id,j.transport_lease_generation]});\n if((u.rows||[]).length)outcomes.push({id:j.id,state:\"FAILED\",reconciled_from_receipt:false,outcome_unknown:true});\n }\n await tx.commit();done=true;return{ok:true,outcomes};\n }catch(e){if(!done){try{await tx.rollback()}catch{}}throw e}\n}\nasync function activeLeases(){\n const r:any=await sqlite.execute(`SELECT id,lease_owner,lease_instance_id,lease_attempt_id,lease_expires_at\n FROM ${JOB_TABLE} WHERE state='LEASED' AND lease_expires_at>datetime('now') ORDER BY id`);\n return r.rows||[];\n}\nfunction atomicizeLeaseSql(sql:string){\n const setNeedle=`SET state='LEASED',lease_owner=?,lease_expires_at=datetime('now','+${LEASE_SECONDS} seconds'),updated_at=datetime('now')`;\n const retNeedle=\"RETURNING id,op,payload_json,priority,lease_expires_at\";\n if(sql.split(setNeedle).length!==2)throw new Error(\"ATOMIC_LEASE_SET_SHAPE_DRIFT\");\n if(sql.split(retNeedle).length!==2)throw new Error(\"ATOMIC_LEASE_RETURNING_SHAPE_DRIFT\");\n return sql.replace(setNeedle,`SET state='LEASED',lease_owner=?,lease_expires_at=datetime('now','+${LEASE_SECONDS} seconds'),transport_lease_generation=transport_lease_generation+1,lease_instance_id=?,lease_attempt_id=?,updated_at=datetime('now')`)\n .replace(retNeedle,\"RETURNING id,op,payload_json,priority,lease_expires_at,transport_lease_generation,lease_instance_id,lease_attempt_id\");\n}\nasync function leaseOne(){\n const gate=await admit();if(!gate.ok)return {kind:\"fenced\",gate} as const;\n await recoverExpiredTransport();\n const active=await activeLeases();\n if(active.length>1)return {kind:\"conflict\",active} as const;\n if(active.length===1)return {kind:\"busy\",active:active[0]} as const;\n const preparedReadOnly=gate.mode===\"PREPARED_READ_ONLY\";\n const attempt=crypto.randomUUID();\n const expectedMode=String(gate.mode);\n let core:any;\n try{\n core=preparedReadOnly\n ? await sqlite.execute({sql:`UPDATE ${JOB_TABLE}\n SET state='LEASED',lease_owner=?,lease_expires_at=datetime('now','+${LEASE_SECONDS} seconds'),\n transport_lease_generation=transport_lease_generation+1,lease_instance_id=?,lease_attempt_id=?,updated_at=datetime('now')\n WHERE id=(\n SELECT j.id FROM ${JOB_TABLE} j\n WHERE j.state='READY' AND j.op='brain'\n AND json_valid(j.payload_json)=1\n AND json_type(j.payload_json,'$.args')='array'\n AND json_array_length(json_extract(j.payload_json,'$.args'))=1\n AND json_extract(j.payload_json,'$.args[0]') IN ('status','verify-chain','verify-claim-graph')\n AND json_type(j.payload_json,'$.timeout')='integer'\n AND json_extract(j.payload_json,'$.timeout') BETWEEN 1 AND 120\n AND (SELECT COUNT(*) FROM json_each(j.payload_json))=2\n AND NOT EXISTS(\n SELECT 1 FROM ${JOB_TABLE} x\n WHERE x.state='LEASED' AND x.lease_expires_at>datetime('now')\n )\n ORDER BY\n CASE json_extract(j.payload_json,'$.args[0]')\n WHEN 'status' THEN 0\n WHEN 'verify-chain' THEN 1\n WHEN 'verify-claim-graph' THEN 2\n ELSE 3\n END,\n CASE WHEN j.priority>1000000000 THEN 1000000000 ELSE j.priority END DESC,\n j.created_at,j.id\n LIMIT 1\n )\n RETURNING id,op,payload_json,priority,lease_expires_at,transport_lease_generation,lease_instance_id,lease_attempt_id`,\n args:[WORKER,INSTANCE,attempt]})\n : EMERGENCY_MUTATIONS_FROZEN\n ? await sqlite.execute({sql:`UPDATE ${JOB_TABLE}\n SET state='LEASED',lease_owner=?,lease_expires_at=datetime('now','+${LEASE_SECONDS} seconds'),\n transport_lease_generation=transport_lease_generation+1,lease_instance_id=?,lease_attempt_id=?,updated_at=datetime('now')\n WHERE id=? AND state='READY'\n AND NOT EXISTS(\n SELECT 1 FROM ${JOB_TABLE}\n WHERE state='LEASED' AND lease_owner=? AND lease_expires_at>datetime('now')\n )\n RETURNING id,op,payload_json,priority,lease_expires_at,transport_lease_generation,lease_instance_id,lease_attempt_id`,\n args:[WORKER,INSTANCE,attempt,EMERGENCY_MUTATION_CANARY_JOB_ID,WORKER]})\n : await sqlite.execute({sql:atomicizeLeaseSql(leaseOneSql(JOB_TABLE)),args:[WORKER,INSTANCE,attempt,WORKER]});\n }catch(e){\n const rr=await reconcileExactLeaseAttemptR2(attempt,gate.epoch,expectedMode,e);\n if(rr.kind===\"leased\")return rr;\n if(rr.kind===\"none\")return {\n kind:\"acquisition_failed_no_bound_lease\",\n attempt_id:attempt,\n reason:e instanceof Error?e.message:String(e),\n } as const;\n return {kind:\"acquisition_outcome_unknown\",attempt_id:attempt,errors:rr.errors} as const;\n }\n const j:any=core.rows?.[0]??null;if(!j)return {kind:\"empty\"} as const;\n if(String(j.lease_instance_id)!==INSTANCE||String(j.lease_attempt_id)!==attempt||Number(j.transport_lease_generation)<1)throw new Error(\"LEASE_ATTEMPT_ATOMICITY_POSTCONDITION_FAILED\");\n return {kind:\"leased\",job:j,epoch:gate.epoch,mode:expectedMode} as const;\n}\nasync function readQueueJob(id:string){\n const r:any=await sqlite.execute({sql:`SELECT * FROM ${JOB_TABLE} WHERE id=?`,args:[id]});\n return r.rows?.[0]??null;\n}\nasync function finishOncePreservingAttempt(job:any,expected:any){\n const r:any=await sqlite.execute({sql:`UPDATE ${JOB_TABLE}\n SET state=?,result_json=?,error_json=?,lease_owner=NULL,lease_expires_at=NULL,updated_at=datetime('now')\n WHERE id=? AND state='LEASED' AND lease_owner=? AND lease_instance_id=? AND lease_attempt_id=? AND transport_lease_generation=? AND op=? AND payload_json=? AND lease_expires_at>datetime('now')\n RETURNING id,state,lease_instance_id,lease_attempt_id,transport_lease_generation`,\n args:[String(expected.state),expected.result_json??null,expected.error_json??null,job.id,String(job.lease_owner||WORKER),String(job.lease_instance_id),String(job.lease_attempt_id),Number(job.transport_lease_generation),String(job.op),String(job.payload_json)]});\n if(!(r.rows||[]).length)return {ok:false,reason:\"RESULT_FENCE_REJECTED_CURRENT_ATTEMPT\"};\n return {ok:true,id:job.id,state:String(expected.state)};\n}\nasync function readMutationReceiptsExact(jobId:string,attemptId:string){\n await ensureMutationReceiptTable();\n const r:any=await sqlite.execute({sql:`SELECT job_id,lease_attempt_id,lease_instance_id,lease_owner,transport_lease_generation,authority_epoch,command,payload_sha256,committed_generation,event_head_hash,result_json,committed_at\n FROM ${MUTATION_RECEIPT_TABLE}\n WHERE job_id=? AND lease_attempt_id=?\n ORDER BY committed_at,job_id,lease_attempt_id`,args:[jobId,attemptId]});\n return r.rows||[];\n}\nfunction sameReceiptRow(a:any,b:any){\n const keys=[\"job_id\",\"lease_attempt_id\",\"lease_instance_id\",\"lease_owner\",\"transport_lease_generation\",\"authority_epoch\",\"command\",\"payload_sha256\",\"committed_generation\",\"event_head_hash\",\"result_json\",\"committed_at\"];\n return keys.every(k=>String(a?.[k]??\"\")===String(b?.[k]??\"\"));\n}\nasync function finalizeExpiredMutationFromReceiptExact(job:any,expected:any,receipt:any){\n await ensureMutationReceiptTable();\n const tx:any=await (sqlite as any).transaction(\"write\");let done=false;\n try{\n const rr:any=await tx.execute({sql:`SELECT job_id,lease_attempt_id,lease_instance_id,lease_owner,transport_lease_generation,authority_epoch,command,payload_sha256,committed_generation,event_head_hash,result_json,committed_at\n FROM ${MUTATION_RECEIPT_TABLE} WHERE job_id=? AND lease_attempt_id=?`,args:[String(job.id),String(job.lease_attempt_id)]});\n const rows:any[]=rr.rows||[];\n if(rows.length!==1||!sameReceiptRow(rows[0],receipt)){\n await tx.rollback();done=true;\n return {ok:false,reason:rows.length>1?\"AMBIGUOUS_MUTATION_RECEIPTS\":\"MUTATION_RECEIPT_CHANGED_OR_MISSING\"};\n }\n const u:any=await tx.execute({sql:`UPDATE ${JOB_TABLE}\n SET state=?,result_json=?,error_json=?,lease_owner=NULL,lease_expires_at=NULL,\n lease_instance_id=?,lease_attempt_id=?,updated_at=datetime('now')\n WHERE id=? AND state='FAILED' AND op=? AND payload_json=? AND transport_lease_generation=?\n AND result_json IS NULL AND lease_owner IS NULL AND lease_expires_at IS NULL\n AND (lease_instance_id IS NULL OR lease_instance_id=?)\n AND (lease_attempt_id IS NULL OR lease_attempt_id=?)\n AND json_valid(error_json)=1\n AND json_extract(error_json,'$.classification')='TRANSPORT_LEASE_EXPIRED_OUTCOME_UNKNOWN_REQUIRES_CANONICAL_RECONCILIATION'\n RETURNING id,state,lease_instance_id,lease_attempt_id,transport_lease_generation`,\n args:[String(expected.state),expected.result_json??null,expected.error_json??null,String(job.lease_instance_id),String(job.lease_attempt_id),\n String(job.id),String(job.op),String(job.payload_json),Number(job.transport_lease_generation),String(job.lease_instance_id),String(job.lease_attempt_id)]});\n if((u.rows||[]).length!==1){\n await tx.rollback();done=true;\n return {ok:false,reason:\"EXPIRED_RECEIPT_RECOVERY_UPDATE_REJECTED\"};\n }\n await tx.commit();done=true;\n return {ok:true,receipt_job_id:String(receipt.job_id)};\n }catch(e){if(!done){try{await tx.rollback()}catch{}}throw e}\n}\nasync function finalizeJobExactAttempt(job:any,epoch:number,mode:string,command:string,dispatchOk:boolean,dispatchValue:any,preDispatchGeneration:number|undefined){\n const helper:any=await resultFinalizationHelperV1();\n const boundJob={...job,lease_owner:WORKER,lease_instance_id:String(job.lease_instance_id),lease_attempt_id:String(job.lease_attempt_id)};\n return await helper.finalizeExactAttemptV1({\n job:boundJob,\n expectedAuthorityEpoch:Number(epoch),\n expectedAuthorityMode:String(mode),\n command:String(command),\n dispatchOk:dispatchOk===true,\n dispatchValue,\n preDispatchGeneration,\n deps:{\n readAuthority:normalizedFinalizationAuthority,\n readJob:readQueueJob,\n readCanonicalGeneration:canonicalGeneration,\n finishOncePreservingAttempt,\n readMutationReceipts:readMutationReceiptsExact,\n finalizeExpiredMutationFromReceipt:finalizeExpiredMutationFromReceiptExact,\n nowIso:()=>new Date().toISOString().replace(\"Z\",\"+00:00\")\n }\n });\n}\nconst CHAIN_FAILURE_READ_ONLY=new Set([\"status\",\"verify-chain\",\"verify-claim-graph\"]);\nconst EMERGENCY_MUTATIONS_FROZEN=false; // Six-core reactivation only; kernel allowlist still fences every unqualified mutator.\nconst EMERGENCY_MUTATION_CANARY_JOB_ID=\"chat-sol-20260907-1528-boundcanary-register\";\nfunction brainCommand(raw:string){\n try{const p=JSON.parse(raw);return Array.isArray(p?.args)?String(p.args[0]||\"\"):\"\"}catch{return \"\"}\n}\nasync function chainCircuitBreaker(raw:string,jobId:string){\n const command=brainCommand(raw);\n if(CHAIN_FAILURE_READ_ONLY.has(command))return {allow:true,command,integrity:null};\n const emergencyCanary=EMERGENCY_MUTATIONS_FROZEN&&jobId===EMERGENCY_MUTATION_CANARY_JOB_ID&&command===\"register-agent\";\n if(EMERGENCY_MUTATIONS_FROZEN&&!emergencyCanary)return {allow:false,command,integrity:{ok:false,reason:\"EPOCH2_MUTATIONS_EMERGENCY_FROZEN_PENDING_ATOMICITY_REPAIR\"}};\n let chain:any,graph:any;\n try{chain=await verifyBrainChain()}\n catch(e){return {allow:false,command,integrity:{ok:false,reason:\"VERIFY_CHAIN_EXCEPTION\",detail:e instanceof Error?e.message:String(e)}}}\n if(chain?.ok!==true)return {allow:false,command,integrity:{chain,graph:null}};\n try{graph=await verifyBrainClaimGraph()}\n catch(e){return {allow:false,command,integrity:{ok:false,reason:\"VERIFY_CLAIM_GRAPH_EXCEPTION\",detail:e instanceof Error?e.message:String(e),chain}}}\n if(graph?.ok!==true)return {allow:false,command,integrity:{chain,graph}};\n return {allow:true,command,integrity:{chain,graph}};\n}\nfunction parseArr(v:any){try{const x=JSON.parse(String(v??\"[]\"));return Array.isArray(x)?x:[]}catch{return []}}\nasync function localCommitSnapshot(taskId:string,agent:string){\n const t:any=(await sqlite.execute({sql:`SELECT id,workstream,state,lease_owner,lease_generation,lease_expires_at,context_manifest,success_condition,decision_value,depends_json,requires_json,writes_json,guards_json\n FROM brainvn_tasks WHERE id=?`,args:[taskId]})).rows?.[0]??null;\n if(!t)return{ok:false,reason:\"TASK_MISSING\"};\n if(String(t.state)!==\"LEASED\"||String(t.lease_owner)!==agent)return{ok:false,reason:\"LEASE_CHANGED\",task:t};\n if(t.lease_expires_at&&String(t.lease_expires_at)<=new Date().toISOString().replace(\"Z\",\"+00:00\"))return{ok:false,reason:\"LEASE_EXPIRED\",task:t};\n const deps=parseArr(t.depends_json),guards=parseArr(t.guards_json);\n const depRows:any[]=[];\n for(const id of deps){\n const r:any=(await sqlite.execute({sql:\"SELECT id,workstream,state,result_event_id FROM brainvn_tasks WHERE id=?\",args:[String(id)]})).rows?.[0]??null;\n depRows.push(r??{id:String(id),state:\"MISSING\"});\n }\n const guardRows:any[]=[];\n let retryGuardSnapshotComplete=true;\n for(const g of guards){\n if(g?.type===\"task_complete\"){\n const r:any=(await sqlite.execute({sql:\"SELECT id,workstream,state,result_event_id FROM brainvn_tasks WHERE id=?\",args:[String(g.id)]})).rows?.[0]??null;\n guardRows.push({guard:g,resolved:r??{id:String(g.id),state:\"MISSING\"}});\n }else if(g?.type===\"claim_verified\"){\n const r:any=(await sqlite.execute({sql:\"SELECT id,workstream,status,updated_at FROM brainvn_claims WHERE id=?\",args:[String(g.id)]})).rows?.[0]??null;\n guardRows.push({guard:g,resolved:r??{id:String(g.id),status:\"MISSING\"}});\n }else{\n retryGuardSnapshotComplete=false;\n guardRows.push({guard:g,resolved:null});\n }\n }\n const ws:any=(await sqlite.execute({sql:\"SELECT id,mission,verified_state FROM brainvn_workstreams WHERE id=?\",args:[String(t.workstream)]})).rows?.[0]??null;\n const stable={\n task:{id:t.id,workstream:t.workstream,state:t.state,lease_owner:t.lease_owner,lease_generation:t.lease_generation,\n context_manifest:t.context_manifest,success_condition:t.success_condition,decision_value:t.decision_value,\n depends_json:t.depends_json,requires_json:t.requires_json,writes_json:t.writes_json,guards_json:t.guards_json},\n dependencies:depRows,guards:guardRows,workstream_semantics:ws\n };\n return{ok:true,stable,lease_expires_at:t.lease_expires_at,workstream:String(t.workstream),retry_guard_snapshot_complete:retryGuardSnapshotComplete};\n}\nfunction sameSnapshot(a:any,b:any){return JSON.stringify(a?.stable)===JSON.stringify(b?.stable)}\nfunction mutationFields(args:any[]){\n let agent=\"\",task=\"\";\n for(let i=1;i{\n let found:number|null=null;\n for(let i=1;iJSON.stringify(k)+\":\"+cohortCanon(x[k])).join(\",\")+\"}\";\n}\nfunction cohortStrictJson(s:any,kind:string){\n try{return JSON.parse(String(s))}\n catch{throw new Error(\"COHORT_BAD_JSON_\"+kind)}\n}\nfunction cohortStrictObjectJson(s:any,kind:string){\n const v=cohortStrictJson(s,kind);\n if(!v||typeof v!==\"object\"||Array.isArray(v))throw new Error(\"COHORT_\"+kind+\"_MUST_BE_OBJECT\");\n return v;\n}\nfunction cohortStrictListJson(s:any,kind:string){\n const v=cohortStrictJson(s,kind);\n if(!Array.isArray(v))throw new Error(\"COHORT_\"+kind+\"_MUST_BE_LIST\");\n return v;\n}\nfunction cohortStrictStringListJson(s:any,kind:string){\n const v=cohortStrictListJson(s,kind);\n if(v.some((x:any)=>typeof x!==\"string\"||!x))throw new Error(\"COHORT_\"+kind+\"_MUST_BE_STRING_LIST\");\n return v;\n}\nfunction cohortCleanCaps(x:any){\n if(!Array.isArray(x)||x.some(v=>typeof v!==\"string\"||!v))throw new Error(\"COHORT_BAD_CAPS\");\n return [...new Set(x)].sort();\n}\nfunction cohortFlagMap(args:any[],start:number,allowed:Set){\n if(!Array.isArray(args)||args.some(x=>typeof x!==\"string\"))return null;\n if((args.length-start)%2!==0)return null;\n const out:any={};\n for(let i=start;i=args.length)return null;\n const name=k.slice(2);\n if(!allowed.has(name)||Object.prototype.hasOwnProperty.call(out,name))return null;\n out[name]=String(args[i+1]);\n }\n return out;\n}\nfunction cohortExactEnvelope(row:any){\n if(String(row?.op)!==\"brain\")return null;\n let q:any;\n try{q=JSON.parse(String(row.payload_json))}\n catch{return null}\n if(!q||typeof q!==\"object\"||Array.isArray(q))return null;\n const keys=Object.keys(q).sort();\n if(keys.length!==2||keys[0]!==\"args\"||keys[1]!==\"timeout\")return null;\n if(!Array.isArray(q.args)||!Number.isInteger(q.timeout)||q.timeout<1||q.timeout>120)return null;\n return q;\n}\nfunction cohortParseRegister(row:any){\n const q=cohortExactEnvelope(row);if(!q||q.args[0]!==\"register-agent\"||typeof q.args[1]!==\"string\"||!q.args[1])return null;\n const f=cohortFlagMap(q.args,2,new Set([\"workstream\",\"role\",\"type\",\"capabilities\"]));if(!f)return null;\n if(f.workstream!==\"global\"||!f.role||f.type!==\"CHAT_UNPROVEN\"||typeof f.capabilities!==\"string\")return null;\n let caps:any;try{caps=cohortCleanCaps(JSON.parse(f.capabilities))}catch{return null}\n return {row,q,member:{id:String(q.args[1]),workstream:\"global\",role:String(f.role),type:\"CHAT_UNPROVEN\",parent:null,capabilities:caps}};\n}\nfunction cohortParseClaim(row:any,agentId:string){\n const q=cohortExactEnvelope(row);if(!q||q.args[0]!==\"claim\")return null;\n const f=cohortFlagMap(q.args,1,new Set([\"agent\",\"mode\",\"lease-seconds\",\"constitution-version\",\"constitution-sha256\",\"registry-version\"]));if(!f)return null;\n if(f.agent!==agentId)return null;\n if(f.mode!==undefined&&f.mode!==\"INTERACTIVE\")return null;\n if(f[\"lease-seconds\"]!==undefined&&f[\"lease-seconds\"]!==\"1800\")return null;\n return {row,q};\n}\nfunction cohortIndependenceSensitive(req:Set,ctx:any){\n if(req.has(\"independent_verification\"))return true;\n const flags=[\n \"identity_gate_pending\",\"prevent_self_review\",\"self_certification_forbidden\",\n \"physical_chat_execution_distinctness_required\",\"reviewer_must_be_distinct\",\n \"reviewer_must_be_distinct_from_refresh_executor\",\"reviewer_must_be_physically_distinct\",\n \"reviewer_must_be_physically_distinct_chat_execution\",\"reviewer_must_differ\",\n \"reviewer_must_differ_from_builder\",\"reviewer_must_differ_from_source_contributors\",\n \"reviewer_population_must_be_distinct\",\"do_not_infer_distinctness_from_agent_id\"\n ];\n if(flags.some(k=>ctx?.[k]===true))return true;\n return ctx?.if_distinctness_not_positively_proven===\"DO_NOT_CLAIM_THIS_TASK\";\n}\nasync function cohortTxRows(tx:any,sql:string,args:any[]=[]){\n const r:any=await tx.execute({sql,args});return r.rows||[];\n}\nasync function cohortTxOne(tx:any,sql:string,args:any[]=[]){\n return (await cohortTxRows(tx,sql,args))[0]??null;\n}\nasync function cohortSnapshot(tx:any){\n return {\n workstreams:await cohortTxRows(tx,\"SELECT * FROM brainvn_workstreams ORDER BY id\"),\n agents:await cohortTxRows(tx,\"SELECT * FROM brainvn_agents ORDER BY id\"),\n tasks:await cohortTxRows(tx,\"SELECT * FROM brainvn_tasks ORDER BY id\"),\n claims:await cohortTxRows(tx,\"SELECT * FROM brainvn_claims ORDER BY id\"),\n deps:await cohortTxRows(tx,\"SELECT * FROM brainvn_claim_deps ORDER BY parent_claim,child_claim\"),\n artifacts:await cohortTxRows(tx,\"SELECT * FROM brainvn_artifacts ORDER BY sha256\")\n };\n}\nfunction cohortParseTask(t:any){\n return {\n row:t,\n ctx:cohortStrictObjectJson(t.context_manifest,\"CTX\"),\n req:cohortStrictStringListJson(t.requires_json,\"REQ\"),\n deps:cohortStrictListJson(t.depends_json,\"DEPS\"),\n guards:cohortStrictListJson(t.guards_json,\"GUARDS\"),\n writes:cohortStrictStringListJson(t.writes_json,\"WRITES\")\n };\n}\nfunction cohortOverlap(a:string[],b:string[]){const B=new Set(b);return a.some(x=>B.has(x))}\nasync function cohortActivationOk(tx:any){\n const meta:any=await cohortTxOne(tx,\"SELECT predecessor_event_count FROM brainvn_epoch_meta WHERE id=1\");\n const t:any=await cohortTxOne(tx,\"SELECT state,result_event_id FROM brainvn_tasks WHERE id=?\",[COHORT_ADMISSION_FASTPATH_V3R2R1_ACTIVATION_TASK]);\n if(!meta||!t||String(t.state)!==\"COMPLETE\"||!Number.isInteger(Number(t.result_event_id)))return false;\n const localSeq=Number(t.result_event_id)-Number(meta.predecessor_event_count);\n if(!Number.isInteger(localSeq)||localSeq<1)return false;\n const ev:any=await cohortTxOne(tx,\"SELECT agent_id,type,task_id FROM brainvn_epoch_events WHERE local_seq=?\",[localSeq]);\n if(!ev||String(ev.type)!==\"TASK_RESULT_COMMITTED\"||String(ev.task_id)!==COHORT_ADMISSION_FASTPATH_V3R2R1_ACTIVATION_TASK||!ev.agent_id)return false;\n const a:any=await cohortTxOne(tx,\"SELECT type FROM brainvn_agents WHERE id=?\",[String(ev.agent_id)]);\n return !!a&&String(a.type)!==\"CHAT_UNPROVEN\";\n}\nfunction cohortOrderedReadySql(){\n const raw=leaseOneSql(JOB_TABLE);\n const start=raw.indexOf(\"SELECT j.id FROM \");\n const limit=raw.indexOf(\"LIMIT 1\",start);\n if(start<0||limit<0)throw new Error(\"COHORT_LEASE_ORDER_SHAPE_DRIFT\");\n let inner=raw.slice(start,limit)+\"LIMIT \"+COHORT_ADMISSION_FASTPATH_V3R2R1_SCAN_JOBS;\n inner=inner.replace(\"SELECT j.id FROM \",\"SELECT j.rowid AS queue_rowid,j.* FROM \");\n const qCount=(inner.match(/\\?/g)||[]).length;\n if(qCount!==1)throw new Error(\"COHORT_LEASE_ORDER_PLACEHOLDER_DRIFT_\"+qCount);\n return inner;\n}\nasync function cohortBaseReceipt(){\n const chain:any=await verifyBrainChain();\n if(chain?.ok!==true)return {ok:false,reason:\"CHAIN_NOT_VERIFIED\",chain};\n const graph:any=await verifyBrainClaimGraph();\n if(graph?.ok!==true)return {ok:false,reason:\"CLAIM_GRAPH_NOT_VERIFIED\",graph};\n const tx:any=await (sqlite as any).transaction(\"read\");let done=false;\n try{\n const meta:any=await cohortTxOne(tx,\"SELECT generation,event_head_hash FROM brainvn_epoch_meta WHERE id=1\");\n const authority:any=await cohortTxOne(tx,\"SELECT epoch,writer,mode,source_generation,source_head FROM \"+AUTH_TABLE+\" WHERE id=1\");\n const state=await cohortSnapshot(tx);\n const digest=await sha256Text(cohortCanon(state));\n if(!meta||Number(meta.generation)!==Number(chain.generation)||String(meta.event_head_hash)!==String(chain.stored_head)){\n await tx.rollback();done=true;return {ok:false,reason:\"CHAIN_RECEIPT_STALE\"};\n }\n if(!authority||String(authority.writer)!==\"val_native\"||String(authority.mode)!==\"ACTIVE\"){\n await tx.rollback();done=true;return {ok:false,reason:\"AUTHORITY_NOT_ACTIVE\"};\n }\n await tx.commit();done=true;\n return {ok:true,generation:Number(meta.generation),head:String(meta.event_head_hash),admission_digest:digest,\n authority:{epoch:Number(authority.epoch),writer:String(authority.writer),mode:String(authority.mode),\n source_generation:Number(authority.source_generation),source_head:String(authority.source_head)}};\n }catch(e){if(!done){try{await tx.rollback()}catch{}}return {ok:false,reason:e instanceof Error?e.message:String(e)}}\n}\nfunction cohortEventBody(e:any){\n return cohortCanon({event_uuid:e.event_uuid,ts:e.ts,workstream:e.workstream,agent_id:e.agent_id,task_id:e.task_id,type:e.type,payload:e.payload,prev_hash:e.prev_hash});\n}\nasync function cohortEventHash(e:any){return await sha256Text(cohortEventBody(e))}\nfunction cohortNow(ms=Date.now()){return new Date(ms).toISOString().replace(\"Z\",\"+00:00\")}\nasync function tryCohortAdmissionFastpathV3R2R1(maxPairs:number){\n if(!COHORT_ADMISSION_FASTPATH_V3R2R1_ENABLED||maxPairsdatetime('now') ORDER BY id LIMIT 2\");\n if(activeInside.length){await tx.rollback();done=true;return {kind:\"not_applicable\"} as const}\n const meta:any=await cohortTxOne(tx,\"SELECT * FROM brainvn_epoch_meta WHERE id=1\");\n const ws:any=await cohortTxOne(tx,\"SELECT * FROM brainvn_workstreams WHERE id='global'\");\n const state=await cohortSnapshot(tx);\n const digest=await sha256Text(cohortCanon(state));\n if(!meta||!ws||Number(meta.generation)!==Number(base.generation)||String(meta.event_head_hash)!==String(base.head)||digest!==String(base.admission_digest)){\n await tx.rollback();done=true;return {kind:\"not_applicable\",reason:\"COHORT_BASE_DRIFT\"} as const;\n }\n if(!(await cohortActivationOk(tx))){\n await tx.rollback();done=true;return {kind:\"not_applicable\",reason:\"COHORT_ACTIVATION_NOT_VERIFIED\"} as const;\n }\n const ordered:any[]=await cohortTxRows(tx,cohortOrderedReadySql(),[WORKER]);\n const pairs:any[]=[];const seen=new Set();\n const pairCap=Math.min(COHORT_ADMISSION_FASTPATH_V3R2R1_MAX_PAIRS,maxPairs);\n for(let i=0;i+1[String(a.id),a]));\n for(const p of pairs)if(existing.has(p.reg.member.id)){\n await tx.rollback();done=true;return {kind:\"not_applicable\",reason:\"COHORT_EXISTING_AGENT\"} as const;\n }\n let ready:any[],leased:any[];\n try{\n ready=state.tasks.filter((t:any)=>String(t.workstream)===\"global\"&&String(t.state)===\"READY\")\n .sort((a:any,b:any)=>Number(b.priority)-Number(a.priority)||String(a.id).localeCompare(String(b.id)))\n .map((t:any)=>cohortParseTask(t));\n leased=state.tasks.filter((t:any)=>String(t.state)===\"LEASED\").map((t:any)=>cohortParseTask(t));\n }catch{\n await tx.rollback();done=true;return {kind:\"not_applicable\",reason:\"COHORT_SCHEDULER_SHAPE_FALLBACK\"} as const;\n }\n const used=new Set(),activeWrites:string[][]=leased.map((p:any)=>p.writes),assignments:any[]=[];\n for(const p of pairs){\n const m=p.reg.member,C=new Set(m.capabilities);let chosen:any=null;\n for(const t0 of ready){\n const t=t0.row;\n if(used.has(String(t.id)))continue;\n if(!t.dedupe_key)continue;\n if(t.assigned_agent!==null&&String(t.assigned_agent)!==m.id)continue;\n if(t0.ctx.execution_allowed===false)continue;\n const sensitive=cohortIndependenceSensitive(new Set(t0.req),t0.ctx);\n if(sensitive&&(m.type===\"CHAT_UNPROVEN\"||COHORT_EXECUTION_DISTINCT_INGRESS_QUALIFIED!==true))continue;\n if(t0.req.some((x:string)=>COHORT_NON_AGENT_CAPS.has(x)))continue;\n if(t0.req.some((x:string)=>!C.has(x)))continue;\n if(t0.deps.length||t0.guards.length){\n await tx.rollback();done=true;return {kind:\"not_applicable\",reason:\"COHORT_DYNAMIC_CAUSAL_FALLBACK\"} as const;\n }\n if(activeWrites.some((x:string[])=>cohortOverlap(t0.writes,x)))continue;\n chosen=t0;used.add(String(t.id));activeWrites.push(t0.writes);break;\n }\n if(!chosen){await tx.rollback();done=true;return {kind:\"not_applicable\",reason:\"COHORT_NO_READY_FALLBACK\"} as const}\n assignments.push({pair:p,member:m,task:chosen});\n }\n\n const queueAttempts:any[]=[];\n for(const a of assignments){\n for(const kind of [\"reg\",\"claim\"]){\n const qr=a.pair[kind].row,attempt=crypto.randomUUID();\n const u:any=await tx.execute({sql:\"UPDATE \"+JOB_TABLE+\" SET state='LEASED',lease_owner=?,lease_expires_at=datetime('now','+\"+LEASE_SECONDS+\" seconds'),transport_lease_generation=transport_lease_generation+1,lease_instance_id=?,lease_attempt_id=?,updated_at=datetime('now') WHERE rowid=? AND id=? AND state='READY' AND op=? AND payload_json=? RETURNING id,op,payload_json,priority,lease_expires_at,transport_lease_generation,lease_instance_id,lease_attempt_id\",\n args:[WORKER,INSTANCE,attempt,Number(qr.queue_rowid),String(qr.id),String(qr.op),String(qr.payload_json)]});\n const row:any=u.rows?.[0]??null;if(!row)throw new Error(\"COHORT_QUEUE_CAS_FAILED_\"+String(qr.id));\n queueAttempts.push({...row,kind,agent_id:a.member.id});\n }\n }\n\n const startGen=Number(meta.generation),startHead=String(meta.event_head_hash);\n let g=startGen,head=startHead;\n const maxSeq:any=await cohortTxOne(tx,\"SELECT COALESCE(MAX(local_seq),0) n FROM brainvn_epoch_events\");\n let seq=Number(maxSeq?.n??0);\n const events:any[]=[],agents:any[]=[],taskUpdates:any[]=[],results:any[]=[];\n const baseMs=Date.now();\n for(let i=0;iArray.from({length:count},()=>(\"(\" + Array.from({length:n},()=>\"?\").join(\",\") + \")\")).join(\",\");\n const aArgs:any[]=[];for(const a of agents)aArgs.push(a.id,a.parent_id,a.type,a.workstream,a.role,a.status,a.boot_generation,a.last_generation,a.last_seen,a.capabilities_json);\n await tx.execute({sql:\"INSERT INTO brainvn_agents(id,parent_id,type,workstream,role,status,boot_generation,last_generation,last_seen,capabilities_json) VALUES \"+valueRows(10,agents.length),args:aArgs});\n const taskIds=taskUpdates.map(x=>x.id);\n const ownerCase=taskUpdates.map(()=>\"WHEN ? THEN ?\").join(\" \"),genCase=taskUpdates.map(()=>\"WHEN ? THEN ?\").join(\" \"),expCase=taskUpdates.map(()=>\"WHEN ? THEN ?\").join(\" \"),updCase=taskUpdates.map(()=>\"WHEN ? THEN ?\").join(\" \");\n const tArgs:any[]=[];for(const t of taskUpdates)tArgs.push(t.id,t.owner);for(const t of taskUpdates)tArgs.push(t.id,t.lease_generation);for(const t of taskUpdates)tArgs.push(t.id,t.lease_expires_at);for(const t of taskUpdates)tArgs.push(t.id,t.updated_at);tArgs.push(...taskIds);\n const tu:any=await tx.execute({sql:\"UPDATE brainvn_tasks SET state='LEASED',lease_owner=CASE id \"+ownerCase+\" END,lease_mode='INTERACTIVE',lease_generation=CASE id \"+genCase+\" END,lease_expires_at=CASE id \"+expCase+\" END,updated_at=CASE id \"+updCase+\" END WHERE id IN (\"+taskIds.map(()=>\"?\").join(\",\")+\") AND state='READY' RETURNING id\",args:tArgs});\n if((tu.rows||[]).length!==taskUpdates.length)throw new Error(\"COHORT_TASK_BULK_CAS_MISMATCH\");\n const eArgs:any[]=[];for(const e of events)eArgs.push(e.local_seq,e.event_uuid,e.ts,e.workstream,e.agent_id,e.task_id,e.type,e.payload_json,e.prev_hash,e.event_hash,e.transaction_generation);\n await tx.execute({sql:\"INSERT INTO brainvn_epoch_events(local_seq,event_uuid,ts,workstream,agent_id,task_id,type,payload_json,prev_hash,event_hash,transaction_generation) VALUES \"+valueRows(11,events.length),args:eArgs});\n const mu:any=await tx.execute({sql:\"UPDATE brainvn_epoch_meta SET generation=?,event_head_hash=?,new_event_count=new_event_count+? WHERE id=1 AND generation=? AND event_head_hash=? RETURNING generation\",args:[g,head,events.length,startGen,startHead]});\n if(!(mu.rows||[]).length)throw new Error(\"COHORT_META_CAS_MISMATCH\");\n await tx.execute({sql:\"UPDATE brainvn_workstreams SET head_generation=?,updated_at=? WHERE id='global'\",args:[g,cohortNow()]});\n\n const byAgent=new Map(results.map(x=>[x.agent_id,x]));\n const outputItems:any[]=[];\n for(const q of queueAttempts){\n const rr:any=byAgent.get(q.agent_id),result=q.kind===\"reg\"?rr.regResult:rr.claimResult;\n const committedGeneration=q.kind===\"reg\"?rr.regGeneration:rr.claimGeneration;\n const committedHead=q.kind===\"reg\"?rr.regHead:rr.claimHead;\n const committedAt=q.kind===\"reg\"?rr.regTs:rr.claimTs;\n const payloadSha=await sha256Text(String(q.payload_json));\n await tx.execute({sql:\"INSERT INTO \"+MUTATION_RECEIPT_TABLE+\"(job_id,lease_attempt_id,lease_instance_id,lease_owner,transport_lease_generation,authority_epoch,command,payload_sha256,committed_generation,event_head_hash,result_json,committed_at) VALUES(?,?,?,?,?,?,?,?,?,?,?,?)\",\n args:[String(q.id),String(q.lease_attempt_id),String(q.lease_instance_id),WORKER,Number(q.transport_lease_generation),Number(authority.epoch),\n q.kind===\"reg\"?\"register-agent\":\"claim\",payloadSha,committedGeneration,committedHead,cohortCanon(result),committedAt]});\n const fq:any=await tx.execute({sql:\"UPDATE \"+JOB_TABLE+\" SET state='COMPLETE',result_json=?,error_json=NULL,lease_owner=NULL,lease_expires_at=NULL,updated_at=datetime('now') WHERE id=? AND state='LEASED' AND lease_owner=? AND lease_instance_id=? AND lease_attempt_id=? AND transport_lease_generation=? AND op=? AND payload_json=? RETURNING id,state\",\n args:[legacyEnvelope(result),String(q.id),WORKER,String(q.lease_instance_id),String(q.lease_attempt_id),Number(q.transport_lease_generation),String(q.op),String(q.payload_json)]});\n if((fq.rows||[]).length!==1)throw new Error(\"COHORT_QUEUE_FINALIZE_CAS_FAILED_\"+String(q.id));\n outputItems.push({id:String(q.id),transport_lease_generation:Number(q.transport_lease_generation),attempt_id:String(q.lease_attempt_id),\n dispatch_ok:true,result,finish:{ok:true,id:String(q.id),state:\"COMPLETE\",path:\"COHORT_ATOMIC_SAME_DB\"},\n cohort_fastpath:{schema:\"COHORT_ADMISSION_FASTPATH_V3R2R1_PRODUCTION_V1\",candidate_sha256:COHORT_ADMISSION_FASTPATH_V3R2R1_CANDIDATE_SHA256,\n pair_count:assignments.length,atomic_same_db:true,serial_pairwise_prefix:true}});\n }\n\n await tx.commit();done=true;\n const postChain:any=await verifyBrainChain(),postGraph:any=await verifyBrainClaimGraph();\n return {kind:\"completed\",items:outputItems,pairs:assignments.length,post_integrity:{chain_ok:postChain?.ok===true,claim_graph_ok:postGraph?.ok===true,\n generation:postChain?.generation,head:postChain?.stored_head},base_generation:startGen,post_generation:g} as const;\n }catch(e){\n if(!done){try{await tx.rollback()}catch{}}\n return {kind:\"not_applicable\",reason:e instanceof Error?e.message:String(e)} as const;\n }\n}\n\nasync function executeJob(job:any,epoch:number){\n const raw=String(job.payload_json);\n const fallbackCommand=brainCommand(raw);\n let command=fallbackCommand;\n let preDispatchGeneration:number|undefined=undefined;\n if(String(job.op)!==\"brain\")return {ok:false,value:{classification:\"VAL_NATIVE_UNSUPPORTED_TRANSPORT_OP\",op:String(job.op)},command,preDispatchGeneration};\n try{\n const gate=await chainCircuitBreaker(raw,String(job.id));\n command=String(gate.command||fallbackCommand||\"\");\n if(!gate.allow)return {ok:false,value:{\n classification:\"VAL_NATIVE_CHAIN_INTEGRITY_CIRCUIT_BREAKER\",\n command:command||\"UNKNOWN\",\n integrity:gate.integrity,\n retry_policy:\"RESTORE_VERIFIED_CHAIN_THEN_SUBMIT_NEW_JOB_ID\",\n canonical_dispatch_performed:false\n },command,preDispatchGeneration};\n if(CHAIN_FAILURE_READ_ONLY.has(command))preDispatchGeneration=await canonicalGeneration();\n const value=await dispatchWithStableMutationRetry(raw,boundTransportContext(job,epoch));\n return {ok:true,value,command,preDispatchGeneration};\n }catch(e){\n return {ok:false,value:{type:e instanceof Error?e.name:\"Error\",detail:e instanceof Error?e.message:String(e)},command,preDispatchGeneration};\n }\n}\nexport async function drain(maxJobs=32){\n const started=new Date().toISOString(),items:any[]=[];\n let runtime_tick:any=null;\n try{runtime_tick=await emitRuntimeTick();}\n catch(e){runtime_tick={ok:false,emitted:false,reason:\"RUNTIME_TICK_WRITE_FAILED\",detail:e instanceof Error?e.message:String(e)};}\n while(items.length=COHORT_ADMISSION_FASTPATH_V3R2R1_MIN_PAIRS*2){\n const cohort:any=await tryCohortAdmissionFastpathV3R2R1(Math.floor(remaining/2));\n if(cohort.kind===\"completed\"){\n items.push(...cohort.items);\n if(cohort.post_integrity?.chain_ok!==true||cohort.post_integrity?.claim_graph_ok!==true){\n return {ok:false,started,finished:new Date().toISOString(),runtime_tick,\n stop:{kind:\"cohort_post_integrity_failed\",post_integrity:cohort.post_integrity},processed:items.length,items};\n }\n continue;\n }\n }\n const l:any=await leaseOne();\n if(l.kind!==\"leased\"){\n const acquisitionFault=l.kind===\"acquisition_failed_no_bound_lease\"||l.kind===\"acquisition_outcome_unknown\";\n return {ok:!acquisitionFault&&l.kind!==\"conflict\"&&l.kind!==\"fenced\",started,finished:new Date().toISOString(),runtime_tick,stop:l,processed:items.length,items};\n }\n const ex=await executeJob(l.job,l.epoch);\n const fin=await finalizeJobExactAttempt(l.job,l.epoch,String(l.mode),String(ex.command||brainCommand(String(l.job.payload_json))),ex.ok,ex.value,ex.preDispatchGeneration);\n items.push({id:l.job.id,transport_lease_generation:l.job.transport_lease_generation,attempt_id:l.job.lease_attempt_id,dispatch_ok:ex.ok,result:ex.value,finish:fin});\n if(!fin.ok)return {ok:false,started,finished:new Date().toISOString(),runtime_tick,stop:fin,processed:items.length,items};\n }\n return {ok:true,started,finished:new Date().toISOString(),runtime_tick,stop:{kind:\"max_jobs\"},processed:items.length,items};\n}\nexport default drain;\n",[],[226,294],["D",1789142945808],[243],[226],["D",1789142237758],["D",1789489912439],{"_98":97,"_106":102},{"_98":97,"_99":100,"_101":102,"_18":53,"_103":104,"_105":24},{"_13":87,"_31":88,"_41":40,"_89":42,"_90":-5,"_91":-5,"_92":-5,"_93":-5,"_94":-5,"_95":43,"_96":97},"ctx",{"_80":-5,"_126":341,"_342":343,"_344":345,"_346":24,"_347":24,"_348":24,"_349":57,"_350":-5,"_351":-7,"_352":-7,"_353":61,"_354":24,"_355":24,"_356":-5,"_357":24,"_358":24,"_359":24,"_360":-5},"ENV",{"_312":313,"_314":315,"_316":88,"_317":318,"_319":320,"_321":322,"_323":324,"_325":326,"_327":328,"_329":330,"_331":332,"_333":334,"_335":336,"_337":338,"_339":340},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","RENDER_GIT_COMMIT","e87eb04e707cf64e7e532c8e8ec395f209e17f15","RENDER_GIT_BRANCH","POSTHOG_API_TOKEN","phc_nmoyuAkStEZuUp69rYlg1DZgrIt19Gx0Y4Hwf8tGgJP","POSTHOG_API_HOST","https://wart.val.town","WEB_API_TEMPLATE","https://{val}.web.val.run","APP_URL","https://www.val.town","MODULE_URL","https://esm.town","VANITY_WEB_API_TEMPLATE","https://{label}.val.run/","DENOLS_URL","https://lsp.val.town","NODE_ENV","production","CLOUDFLARE_TURNSTILE_SITE_KEY","0x4AAAAAACtaIZJH7s9rBMZ6","GOOGLE_CLIENT_ID","875989696899-jtsqkhlbdv5jrlsk8631p7ipjg3c6o62.apps.googleusercontent.com","STRIPE_PUBLISHABLE_KEY","pk_live_51N2zvWEpZTTLipIkVEwXrUG9AT0yeOOEYxszarZT1jpsZV58Ly6wlg3SltZpHN26CUalOBmUSY7adQRQiSkCZz2500qSXNkf8Y","API_URL","https://api.val.town",[],"preferencesKeybindings","default","preferencesTheme","light","preferencesFixers","preferencesCopilot","preferencesSelectionAi","preferencesCloseBrackets","preferencesChatPanelState","preferencesDprint","preferencesDenofmt","notificationCount","flagDenols","isBusinessOrgMember","businessOrgHandle","isBusinessOrgAdmin","isHigherTownieTier","navCollapsed","currentOrgId"]

Diff · v23