[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_205":206,"_207":208},"routes/_app.x.$handle.$name",{"_11":12,"_13":14,"_15":16,"_17":18,"_38":-7,"_121":-5,"_19":122,"_123":124,"_125":126,"_127":128,"_129":130,"_21":131,"_132":-5,"_133":-5,"_134":24,"_135":136,"_137":24,"_138":-5,"_139":-5,"_140":141},"routes/_app.x.$handle.$name.branch.$branch.history_.$",{"_11":12,"_13":14,"_15":16,"_17":18,"_19":20,"_21":22,"_23":24,"_25":26,"_27":28,"_29":24,"_30":-5},"handle","mosadek","name","brain-lane-review-20260909-k4x9p2","branchName","main","path","review3.ts","project",{"_32":72,"_13":14,"_36":73,"_74":-5,"_75":24,"_76":77,"_78":77,"_79":80,"_81":-5,"_30":68,"_82":-5,"_83":24,"_84":-5,"_85":-5,"_86":26,"_40":41,"_87":-5,"_88":-5,"_89":-5,"_90":-5,"_91":92,"_93":92,"_94":95,"_96":95,"_97":95,"_98":92,"_99":92,"_53":100,"_101":102,"_103":104,"_105":24},"file",{"_63":64,"_13":18,"_65":66,"_67":24,"_71":-5},"isDirectory",false,"page",0,"history",[31],"hasNext","userId",{"_32":33,"_34":35,"_36":37,"_38":39,"_40":41,"_42":43,"_44":-5,"_45":-5,"_46":-5,"_47":-5,"_48":-5,"_49":50,"_51":52,"_53":54,"_21":55,"_56":-5,"_57":-5,"_58":-5,"_59":-5,"_60":61},"id","88c79a6c-a2e2-426c-92ed-314b4b75aab9","branchId","a65f7dbd-84ab-43f7-8bce-f475977936c3","createdAt",["D",1788984671706],"version",3,"orgId","01a0715b-703f-741f-ab35-c85020e4a5e0","parentId","e2ac7c73-2dda-4b97-9cd7-5df696195a48","incomingCommitId","aiChatMessageId","aiChatThreadId","aiChatThreadUserId","aiChatThreadTitle","source","mcp","clientLabel","ChatGPT","user",{"_32":68,"_40":41,"_11":12,"_69":70},{"_63":64,"_13":18,"_65":66,"_67":24},"pull","merge","revert","multiple","commits",[62],{"_32":33,"_34":35,"_36":37,"_38":39,"_40":41,"_42":43,"_44":-5,"_45":-5,"_46":-5,"_47":-5,"_48":-5,"_49":50,"_51":52,"_53":54,"_21":55,"_56":-5,"_57":-5,"_58":-5},"fileId","9a2b4c50-ac8a-11f1-a1b8-1607ee4eb77e","fileType","script","deleted","6be0fc5c-1fef-4bd6-a1e1-67a3f8c0764e","avatar","https://lh3.googleusercontent.com/a/ACg8ocL1eT_LHhKSg5px3nXIO6eez79aZXef466qXKh2gak-0iwrvw=s96-c","deletedAtVersion","c0aba5bc-71d5-4f90-a196-f1ca17a01802",["D",1788984469538],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","Isolated second-party lane review","imageUrl","pinnedFileId","pinPreview","pinMigrated","screenshotVersion","likeCount","tursoName","tursoHostname","tursoMeasuredAt","pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm",{"_11":12,"_120":70},"org",{"_11":12,"_115":116,"_69":70,"_30":68,"_117":118,"_119":24},"branch",{"_38":106,"_13":16,"_32":35,"_107":72,"_108":-5,"_109":-5,"_110":-5,"_111":-5,"_112":-5,"_113":14,"_114":12},"isOwned",5,"projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","displayName","Mo Sadek","tier","free","canRestrictVals","profileImageUrl","adoptOrgId",{"_32":72,"_13":14,"_36":201,"_74":-5,"_75":24,"_76":77,"_78":77,"_79":80,"_81":-5,"_30":68,"_82":-5,"_83":24,"_84":-5,"_85":-5,"_86":26,"_40":41,"_87":-5,"_88":-5,"_89":-5,"_90":-5,"_91":92,"_93":92,"_94":95,"_96":95,"_97":95,"_98":92,"_99":92,"_53":202,"_101":203,"_103":204,"_105":24},"tree",[160,161,162,163,164],"files",[160,161,162,163,164],"counts",{"_149":26,"_150":151,"_152":26,"_153":154,"_155":156},"contents",[],{"_32":142,"_34":35,"_63":64,"_13":18,"_143":144,"_65":66,"_38":26,"_42":-5,"_36":145,"_146":39,"_147":-5,"_17":148},"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},"0e228028-dcc8-45c0-bf78-796f78da6490","content","const P=\"{\\n \\\"schema\\\": \\\"ABANDONED_TRANSPORT_LANE_ISOLATION_FROZEN_REVIEW_PACKET_V2\\\",\\n \\\"classification\\\": \\\"CANDIDATE_ONLY_SECOND_PARTY_REVIEW_PACKET\\\",\\n \\\"task\\\": \\\"BRAIN-VAL-NATIVE-ABANDONED-TRANSPORT-LANE-ISOLATION-SECOND-PARTY-REVIEW-V1-20260908\\\",\\n \\\"producer\\\": \\\"chat-unproven-gpt56sol-20260909-2158-bbn-r1-k4x9p2\\\",\\n \\\"current_production_executor\\\": {\\n \\\"bytes\\\": 43706,\\n \\\"sha256\\\": \\\"dc142fb629c3197d79f0a9f772b639169ec86598d7b65a7f08a1c8b7c77adf0f\\\"\\n },\\n \\\"candidate_base\\\": {\\n \\\"path\\\": \\\"val_native_executor_prod.ts\\\",\\n \\\"version\\\": 2262,\\n \\\"bytes\\\": 25168,\\n \\\"sha256\\\": \\\"5547fe98a5ae7bc59c212f5867bb1d386542b6114e3001d88c64e0aeb15d5d05\\\"\\n },\\n \\\"candidate\\\": {\\n \\\"bytes\\\": 26742,\\n \\\"sha256\\\": \\\"1c6b354bae0c5aecf55555343b3dc76638d1dcb8333d855ce987e6735e904c49\\\",\\n \\\"source\\\": \\\"import { sqlite } from \\\\\\\"https://esm.town/v/std/sqlite/main.ts\\\\\\\";\\\\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\\\\\\\";\\\\nconst WORKER=\\\\\\\"project-brain-val-native-v1\\\\\\\";\\\\nconst INSTANCE=\\\\\\\"val-native-epoch2\\\\\\\";\\\\nconst LEASE_SECONDS=180;\\\\nconst TRANSPORT_PAYLOAD_TIMEOUT_MAX=120;\\\\nfunction readOnlyTransportSql(alias:string){\\\\n return `(${alias}.op='brain' AND json_valid(${alias}.payload_json)=1\\\\n AND json_type(${alias}.payload_json,'$.args')='array'\\\\n AND json_array_length(json_extract(${alias}.payload_json,'$.args'))=1\\\\n AND json_extract(${alias}.payload_json,'$.args[0]') IN ('status','verify-chain','verify-claim-graph')\\\\n AND json_type(${alias}.payload_json,'$.timeout')='integer'\\\\n AND json_extract(${alias}.payload_json,'$.timeout') BETWEEN 1 AND ${TRANSPORT_PAYLOAD_TIMEOUT_MAX}\\\\n AND (SELECT COUNT(*) FROM json_each(${alias}.payload_json))=2)`;\\\\n}\\\\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}\\\\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,lease_instance_id=NULL,lease_attempt_id=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 activeMutationLeases(){\\\\n const ro=readOnlyTransportSql(\\\\\\\"j\\\\\\\");\\\\n const r:any=await sqlite.execute(`SELECT j.id,j.lease_owner,j.lease_instance_id,j.lease_attempt_id,j.lease_expires_at\\\\n FROM ${JOB_TABLE} j\\\\n WHERE j.state='LEASED' AND j.lease_expires_at>datetime('now')\\\\n AND NOT ${ro}\\\\n ORDER BY j.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}\\\\nfunction laneAwareLeaseSql(sql:string){\\\\n const needle=`AND NOT EXISTS(\\\\n SELECT 1 FROM ${JOB_TABLE} x\\\\n WHERE x.state='LEASED' AND x.lease_owner=? AND x.lease_expires_at > datetime('now')\\\\n )`;\\\\n if(sql.split(needle).length!==2)throw new Error(\\\\\\\"LANE_AWARE_LEASE_GATE_SHAPE_DRIFT\\\\\\\");\\\\n const readCandidate=readOnlyTransportSql(\\\\\\\"j\\\\\\\");\\\\n const readActive=readOnlyTransportSql(\\\\\\\"x\\\\\\\");\\\\n return sql.replace(needle,`AND (\\\\n ${readCandidate}\\\\n OR NOT EXISTS(\\\\n SELECT 1 FROM ${JOB_TABLE} x\\\\n WHERE x.state='LEASED' AND x.lease_owner=? AND x.lease_expires_at > datetime('now')\\\\n AND NOT ${readActive}\\\\n )\\\\n )`);\\\\n}\\\\nasync function leaseOne(){\\\\n const gate=await admit();if(!gate.ok)return {kind:\\\\\\\"fenced\\\\\\\",gate} as const;\\\\n await recoverExpiredTransport();\\\\n const activeMutations=await activeMutationLeases();\\\\n if(activeMutations.length>1)return {kind:\\\\\\\"conflict\\\\\\\",active:activeMutations} 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:laneAwareLeaseSql(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;\\\\n if(!j){\\\\n if(activeMutations.length===1)return {kind:\\\\\\\"busy_mutation\\\\\\\",active:activeMutations[0]} as const;\\\\n return {kind:\\\\\\\"empty\\\\\\\"} as const;\\\\n }\\\\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} as const;\\\\n}\\\\nasync function finish(job:any,epoch:number,ok:boolean,value:any){\\\\n const gate=await admit();\\\\n if(!gate.ok||Number(gate.epoch)!==epoch){\\\\n return {ok:false,reason:\\\\\\\"CONTROL_PLANE_RESULT_FENCED\\\\\\\",authority:gate.authority??null};\\\\n }\\\\n const result=ok?legacyEnvelope(value):null;\\\\n const error=ok?null:JSON.stringify(value);\\\\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,lease_instance_id=NULL,lease_attempt_id=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`,\\\\n args:[ok?\\\\\\\"COMPLETE\\\\\\\":\\\\\\\"FAILED\\\\\\\",result,error,job.id,WORKER,INSTANCE,job.lease_attempt_id,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:ok?\\\\\\\"COMPLETE\\\\\\\":\\\\\\\"FAILED\\\\\\\"};\\\\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;idatetime('now')\\\\n AND NOT {ro('x')}\\\\n ))\\\\n ORDER BY priority DESC, created_at, j.rowid LIMIT 1)\\\\n RETURNING id,transport_lease_generation,lease_attempt_id\\\\\\\"\\\\\\\"\\\\\\\"\\\\n r=db.execute(sql,(WORKER,INSTANCE,attempt,WORKER)).fetchone(); db.commit()\\\\n return dict(r) if r else None\\\\n\\\\ndef finish(db,id,attempt,generation):\\\\n r=db.execute(\\\\\\\"\\\\\\\"\\\\\\\"UPDATE jobs SET state='COMPLETE',result_json='{}',error_json=NULL,\\\\n lease_owner=NULL,lease_expires_at=NULL,lease_instance_id=NULL,lease_attempt_id=NULL,updated_at=datetime('now')\\\\n WHERE id=? AND state='LEASED' AND lease_owner=? AND lease_instance_id=? AND lease_attempt_id=?\\\\n AND transport_lease_generation=? AND lease_expires_at>datetime('now') RETURNING id,state\\\\\\\"\\\\\\\"\\\\\\\",\\\\n (id,WORKER,INSTANCE,attempt,generation)).fetchone(); db.commit()\\\\n return dict(r) if r else None\\\\n\\\\ndef recover(db):\\\\n ids=[r[\\\\\\\"id\\\\\\\"] for r in db.execute(\\\\\\\"\\\\\\\"\\\\\\\"SELECT id FROM jobs WHERE state='LEASED'\\\\n AND lease_expires_at IS NOT NULL AND lease_expires_at<=datetime('now')\\\\\\\"\\\\\\\"\\\\\\\")]\\\\n for id in ids:\\\\n db.execute(\\\\\\\"\\\\\\\"\\\\\\\"UPDATE jobs SET state='FAILED',result_json=NULL,\\\\n error_json=json_object('classification','TRANSPORT_LEASE_EXPIRED_OUTCOME_UNKNOWN_REQUIRES_CANONICAL_RECONCILIATION'),\\\\n lease_owner=NULL,lease_expires_at=NULL,lease_instance_id=NULL,lease_attempt_id=NULL\\\\n WHERE id=?\\\\\\\"\\\\\\\"\\\\\\\",(id,))\\\\n db.commit(); return ids\\\\n\\\\ndef active_mutations(db):\\\\n return [r[\\\\\\\"id\\\\\\\"] for r in db.execute(f\\\\\\\"\\\\\\\"\\\\\\\"SELECT id FROM jobs j WHERE state='LEASED'\\\\n AND lease_expires_at>datetime('now') AND NOT {ro('j')} ORDER BY id\\\\\\\"\\\\\\\"\\\\\\\")]\\\\n\\\\nT=[]\\\\ndef check(name,cond): T.append((name,bool(cond)))\\\\n\\\\n# mutation blocks mutation, not read\\\\ndb=setup(); add(db,\\\\\\\"m0\\\\\\\",\\\\\\\"commit\\\\\\\",\\\\\\\"LEASED\\\\\\\",owner=WORKER,expires=\\\\\\\"2099-01-01 00:00:00\\\\\\\",attempt=\\\\\\\"m0\\\\\\\",generation=1)\\\\nadd(db,\\\\\\\"m1\\\\\\\",\\\\\\\"claim\\\\\\\",priority=200); add(db,\\\\\\\"r1\\\\\\\",\\\\\\\"status\\\\\\\",priority=100)\\\\na=lease(db,\\\\\\\"a\\\\\\\"); b=lease(db,\\\\\\\"b\\\\\\\")\\\\ncheck(\\\\\\\"mutation_allows_read\\\\\\\",a and a[\\\\\\\"id\\\\\\\"]==\\\\\\\"r1\\\\\\\"); check(\\\\\\\"mutation_blocks_second_mutation\\\\\\\",b is None)\\\\n\\\\n# read blocks nothing\\\\ndb=setup(); add(db,\\\\\\\"r0\\\\\\\",\\\\\\\"verify-chain\\\\\\\",\\\\\\\"LEASED\\\\\\\",owner=WORKER,expires=\\\\\\\"2099-01-01 00:00:00\\\\\\\",attempt=\\\\\\\"r0\\\\\\\",generation=1)\\\\nadd(db,\\\\\\\"m1\\\\\\\",\\\\\\\"commit\\\\\\\",priority=200); add(db,\\\\\\\"r1\\\\\\\",\\\\\\\"status\\\\\\\",priority=100)\\\\na=lease(db,\\\\\\\"a\\\\\\\"); b=lease(db,\\\\\\\"b\\\\\\\")\\\\ncheck(\\\\\\\"read_does_not_block_mutation\\\\\\\",a and a[\\\\\\\"id\\\\\\\"]==\\\\\\\"m1\\\\\\\"); check(\\\\\\\"read_concurrency_after_mutation_lease\\\\\\\",b and b[\\\\\\\"id\\\\\\\"]==\\\\\\\"r1\\\\\\\")\\\\n\\\\n# exact attempt finish\\\\ndb=setup(); add(db,\\\\\\\"r\\\\\\\",\\\\\\\"status\\\\\\\"); a=lease(db,\\\\\\\"good\\\\\\\")\\\\ncheck(\\\\\\\"wrong_attempt_finish_rejected\\\\\\\",finish(db,\\\\\\\"r\\\\\\\",\\\\\\\"bad\\\\\\\",a[\\\\\\\"transport_lease_generation\\\\\\\"]) is None)\\\\ncheck(\\\\\\\"exact_attempt_finish_accepted\\\\\\\",finish(db,\\\\\\\"r\\\\\\\",\\\\\\\"good\\\\\\\",a[\\\\\\\"transport_lease_generation\\\\\\\"]) is not None)\\\\n\\\\n# expiry unknown and progress\\\\ndb=setup(); add(db,\\\\\\\"old\\\\\\\",\\\\\\\"commit\\\\\\\",\\\\\\\"LEASED\\\\\\\",owner=WORKER,expires=\\\\\\\"2000-01-01 00:00:00\\\\\\\",attempt=\\\\\\\"o\\\\\\\",generation=1); add(db,\\\\\\\"next\\\\\\\",\\\\\\\"claim\\\\\\\")\\\\nids=recover(db); old=db.execute(\\\\\\\"SELECT * FROM jobs WHERE id='old'\\\\\\\").fetchone(); nxt=lease(db,\\\\\\\"n\\\\\\\")\\\\ncheck(\\\\\\\"expired_mutation_unknown\\\\\\\", \\\\\\\"old\\\\\\\" in ids and old[\\\\\\\"state\\\\\\\"]==\\\\\\\"FAILED\\\\\\\" and \\\\\\\"OUTCOME_UNKNOWN\\\\\\\" in old[\\\\\\\"error_json\\\\\\\"])\\\\ncheck(\\\\\\\"progress_after_expiry\\\\\\\",nxt and nxt[\\\\\\\"id\\\\\\\"]==\\\\\\\"next\\\\\\\")\\\\n\\\\n# terminal no replay\\\\ndb=setup(); add(db,\\\\\\\"r\\\\\\\",\\\\\\\"status\\\\\\\"); a=lease(db,\\\\\\\"a\\\\\\\"); finish(db,\\\\\\\"r\\\\\\\",\\\\\\\"a\\\\\\\",a[\\\\\\\"transport_lease_generation\\\\\\\"])\\\\ncheck(\\\\\\\"terminal_not_replayed\\\\\\\",lease(db,\\\\\\\"b\\\\\\\") is None)\\\\n\\\\n# malformed fail closed for mutation but not reads\\\\ndb=setup(); add(db,\\\\\\\"bad\\\\\\\",\\\\\\\"status\\\\\\\",\\\\\\\"LEASED\\\\\\\",owner=WORKER,expires=\\\\\\\"2099-01-01 00:00:00\\\\\\\",attempt=\\\\\\\"x\\\\\\\",generation=1,payload_json=payload(\\\\\\\"status\\\\\\\",extra=True))\\\\nadd(db,\\\\\\\"m\\\\\\\",\\\\\\\"claim\\\\\\\",priority=200); add(db,\\\\\\\"r\\\\\\\",\\\\\\\"verify-claim-graph\\\\\\\",priority=100)\\\\ncheck(\\\\\\\"malformed_active_is_mutation_class\\\\\\\",active_mutations(db)==[\\\\\\\"bad\\\\\\\"])\\\\na=lease(db,\\\\\\\"r1\\\\\\\"); b=lease(db,\\\\\\\"m1\\\\\\\")\\\\ncheck(\\\\\\\"malformed_active_allows_closed_read\\\\\\\",a and a[\\\\\\\"id\\\\\\\"]==\\\\\\\"r\\\\\\\")\\\\ncheck(\\\\\\\"malformed_active_blocks_mutation\\\\\\\",b is None)\\\\n\\\\n# lanes\\\\ndb=setup(); add(db,\\\\\\\"m1\\\\\\\",\\\\\\\"commit\\\\\\\",priority=200); add(db,\\\\\\\"m2\\\\\\\",\\\\\\\"claim\\\\\\\",priority=100)\\\\na=lease(db,\\\\\\\"1\\\\\\\"); b=lease(db,\\\\\\\"2\\\\\\\")\\\\ncheck(\\\\\\\"single_flight_mutation\\\\\\\",a and a[\\\\\\\"id\\\\\\\"]==\\\\\\\"m1\\\\\\\" and b is None)\\\\ndb=setup(); add(db,\\\\\\\"r1\\\\\\\",\\\\\\\"status\\\\\\\",priority=200); add(db,\\\\\\\"r2\\\\\\\",\\\\\\\"verify-chain\\\\\\\",priority=100)\\\\na=lease(db,\\\\\\\"1\\\\\\\"); b=lease(db,\\\\\\\"2\\\\\\\")\\\\ncheck(\\\\\\\"concurrent_reads\\\\\\\",a and b and {a[\\\\\\\"id\\\\\\\"],b[\\\\\\\"id\\\\\\\"]}=={\\\\\\\"r1\\\\\\\",\\\\\\\"r2\\\\\\\"})\\\\n\\\\nresult={\\\\\\\"schema\\\\\\\":\\\\\\\"ABANDONED_TRANSPORT_LANE_ISOLATION_HARNESS_V2\\\\\\\",\\\\\\\"pass\\\\\\\":all(v for _,v in T),\\\\n \\\\\\\"test_count\\\\\\\":len(T),\\\\\\\"failed\\\\\\\":[n for n,v in T if not v],\\\\n \\\\\\\"tests\\\\\\\":[{\\\\\\\"name\\\\\\\":n,\\\\\\\"pass\\\\\\\":v} for n,v in T]}\\\\nprint(json.dumps(result,separators=(\\\\\\\",\\\\\\\",\\\\\\\":\\\\\\\")))\\\\n\\\"\\n },\\n \\\"reconstruction_proof\\\": {\\n \\\"bytes\\\": 656,\\n \\\"sha256\\\": \\\"d80d0dfcbf73de788e3aa922b4e4c49df4d61d66786cd89b90aa4000adb759a4\\\"\\n },\\n \\\"identity_match_to_execution_receipt\\\": true\\n },\\n \\\"execution_receipt\\\": {\\n \\\"bytes\\\": 1817,\\n \\\"sha256\\\": \\\"4f44a4a46997c065c05626d3a6c539203b32ca84d618689f42c80bbd40ee4ee4\\\",\\n \\\"content\\\": {\\n \\\"schema\\\": \\\"ABANDONED_TRANSPORT_LANE_ISOLATION_HARNESS_EXECUTION_RECEIPT_V2\\\",\\n \\\"classification\\\": \\\"LOCAL_ISOLATED_EXECUTION_EVIDENCE_CANDIDATE_NONAUTHORITY\\\",\\n \\\"harness_bytes\\\": 6734,\\n \\\"harness_sha256\\\": \\\"b7ea9fe9410234d5f7ae19549188410e057f6de768d41084946d8f941cccedc0\\\",\\n \\\"interpreter\\\": \\\"CPython sqlite3 in-memory\\\",\\n \\\"exit_code\\\": 0,\\n \\\"stdout_json\\\": {\\n \\\"schema\\\": \\\"ABANDONED_TRANSPORT_LANE_ISOLATION_HARNESS_V2\\\",\\n \\\"pass\\\": true,\\n \\\"test_count\\\": 14,\\n \\\"failed\\\": [],\\n \\\"tests\\\": [\\n {\\n \\\"name\\\": \\\"mutation_allows_read\\\",\\n \\\"pass\\\": true\\n },\\n {\\n \\\"name\\\": \\\"mutation_blocks_second_mutation\\\",\\n \\\"pass\\\": true\\n },\\n {\\n \\\"name\\\": \\\"read_does_not_block_mutation\\\",\\n \\\"pass\\\": true\\n },\\n {\\n \\\"name\\\": \\\"read_concurrency_after_mutation_lease\\\",\\n \\\"pass\\\": true\\n },\\n {\\n \\\"name\\\": \\\"wrong_attempt_finish_rejected\\\",\\n \\\"pass\\\": true\\n },\\n {\\n \\\"name\\\": \\\"exact_attempt_finish_accepted\\\",\\n \\\"pass\\\": true\\n },\\n {\\n \\\"name\\\": \\\"expired_mutation_unknown\\\",\\n \\\"pass\\\": true\\n },\\n {\\n \\\"name\\\": \\\"progress_after_expiry\\\",\\n \\\"pass\\\": true\\n },\\n {\\n \\\"name\\\": \\\"terminal_not_replayed\\\",\\n \\\"pass\\\": true\\n },\\n {\\n \\\"name\\\": \\\"malformed_active_is_mutation_class\\\",\\n \\\"pass\\\": true\\n },\\n {\\n \\\"name\\\": \\\"malformed_active_allows_closed_read\\\",\\n \\\"pass\\\": true\\n },\\n {\\n \\\"name\\\": \\\"malformed_active_blocks_mutation\\\",\\n \\\"pass\\\": true\\n },\\n {\\n \\\"name\\\": \\\"single_flight_mutation\\\",\\n \\\"pass\\\": true\\n },\\n {\\n \\\"name\\\": \\\"concurrent_reads\\\",\\n \\\"pass\\\": true\\n }\\n ]\\n },\\n \\\"production_mutation\\\": false,\\n \\\"direct_sprites_calls\\\": 0,\\n \\\"human_authority_approval\\\": false,\\n \\\"p_real_increment\\\": 0\\n }\\n },\\n \\\"explicit_invariants\\\": [\\n \\\"at most one active mutation transport lease\\\",\\n \\\"exact closed-schema status/verify-chain/verify-claim-graph may coexist with active mutation and with each other\\\",\\n \\\"malformed or unknown active transport payload is mutation-class fail-closed\\\",\\n \\\"preserve exact-attempt result fencing\\\",\\n \\\"preserve expired mutation UNKNOWN_OUTCOME semantics\\\",\\n \\\"terminal jobs are never replayed\\\",\\n \\\"PREPARED_READ_ONLY admits only exact read-only commands\\\",\\n \\\"reconcileExactLeaseAttemptR2 cannot convert ambiguous acquisition into unsafe progress\\\",\\n \\\"transformed lease SQL must remain placeholder-compatible with leaseOneSql\\\",\\n \\\"no duplicate canonical mutation execution\\\"\\n ],\\n \\\"required_attacks\\\": [\\n \\\"mutation single-flight\\\",\\n \\\"read/mutation lane arbitration\\\",\\n \\\"malformed payload classification\\\",\\n \\\"exact-attempt finish fencing\\\",\\n \\\"expired mutation UNKNOWN_OUTCOME behavior\\\",\\n \\\"replay\\\",\\n \\\"PREPARED_READ_ONLY semantics\\\",\\n \\\"reconcileExactLeaseAttemptR2 semantics\\\",\\n \\\"queue ordering\\\",\\n \\\"transformed lease SQL placeholder compatibility\\\",\\n \\\"harness/receipt identity mismatch\\\"\\n ],\\n \\\"authority_effects\\\": {\\n \\\"canonical_mutation\\\": false,\\n \\\"production_mutation\\\": false,\\n \\\"p_real_increment\\\": 0,\\n \\\"independent_review_claimed\\\": false,\\n \\\"human_authority_approval\\\": false,\\n \\\"direct_sprites_calls\\\": 0,\\n \\\"additional_out_of_pocket_spend_usd\\\": 0\\n }\\n}\\n\",H=\"1645c8505e8f58e8f4427baff20b6707fc353e6a3f9c2650999bfb5518e9da83\";\nasync 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(\"\")}\nif(await sha(P)!==H)throw new Error(\"PACKET_HASH_MISMATCH\");\nconst model=\"stepfun/step-3.7-flash:free\",gateway=\"https://api.kilo.ai/api/gateway/chat/completions\";\nconst prompt=[\n\"Audit exact frozen packet SHA \"+H+\" as a distinct second-party correctness reviewer.\",\n\"Review every required_attacks item. A COUNTEREXAMPLE requires an ordered reachable state transition satisfying all source preconditions and a precise candidate construct.\",\n\"Do not use the previously corrupted harness; V2 includes a reconstructed exact source whose 6734-byte SHA matches the original execution receipt.\",\n\"Separate THREE judgments: candidate_internal_semantics, evidence_integrity, and integration_readiness_against_current_production.\",\n\"The candidate base hash differs from current production executor hash. Because packet intentionally contains only the current production hash, not its source, do not claim current-production rebase compatibility unless mechanically supported.\",\n\"PASS candidate semantics only if no reachable counterexample is found across mutation single-flight, lane arbitration, malformed classification, exact-attempt finish, expiry UNKNOWN_OUTCOME, replay, PREPARED_READ_ONLY, reconcileExactLeaseAttemptR2, queue ordering, and transformed SQL placeholder shape.\",\n\"Return ONLY JSON keys overall_verdict,candidate_internal_semantics,evidence_integrity,integration_readiness,attacks,reachable_counterexamples,minimum_fix.\"\n].join(\"\\n\")+\"\\nPACKET:\\n\"+P;\nconst started=new Date().toISOString(),t=Date.now();\nconst resp=await fetch(gateway,{method:\"POST\",headers:{\"content-type\":\"application/json\"},body:JSON.stringify({model,messages:[{role:\"user\",content:prompt}],temperature:0,max_tokens:3000,stream:false,response_format:{type:\"json_object\"}})});\nconst raw=await resp.text(),finished=new Date().toISOString();\nif(!resp.ok){console.log(JSON.stringify({schema:\"ABANDONED_TRANSPORT_LANE_EXTERNAL_REVIEW_V3\",packet_sha256:H,model,started,finished,http_status:resp.status,error:raw.slice(0,1000)},null,2));}\nelse{const j=JSON.parse(raw),m=j?.choices?.[0]?.message??{};let review:any=null,rv=\"\";for(const c of [m.content,m.reasoning_content,m.reasoning,j?.choices?.[0]?.text]){if(typeof c!==\"string\"||!c.trim())continue;const a=c.indexOf(\"{\"),b=c.lastIndexOf(\"}\");if(a>=0&&b>=a){try{review=JSON.parse(c.slice(a,b+1));rv=c;break}catch{}}}\nconsole.log(JSON.stringify({schema:\"ABANDONED_TRANSPORT_LANE_EXTERNAL_REVIEW_V3\",packet_sha256:H,packet_hash_verified:true,model,returned_model:j?.model??null,provider_response_id:j?.id??null,started,finished,ms:Date.now()-t,http_status:resp.status,usage:j?.usage??null,reported_cost:j?.usage?.cost??null,review,raw_verdict:rv,raw_verdict_sha256:rv?await sha(rv):null},null,2));}",["D",1788984671706],"branchVersion","label",[18],"pulls","branches",1,"forks","envVars",{"_157":26,"_159":26},"connections",{"_157":26,"_158":26},"count","unfilledCount","emptyCount",{"_32":194,"_13":195,"_63":196,"_42":-5,"_34":35,"_146":151,"_168":169,"_36":197,"_38":26,"_65":66,"_143":198,"_67":24,"_147":-5,"_172":199,"_17":200},{"_32":186,"_13":187,"_63":188,"_42":-5,"_34":35,"_146":189,"_168":169,"_36":190,"_38":26,"_65":66,"_143":191,"_67":24,"_147":-5,"_172":192,"_17":193},{"_32":142,"_13":18,"_63":64,"_42":-5,"_34":35,"_146":39,"_168":169,"_36":183,"_38":26,"_65":66,"_143":144,"_67":24,"_147":-5,"_172":184,"_17":185},{"_32":175,"_13":176,"_63":177,"_42":-5,"_34":35,"_146":178,"_168":169,"_36":179,"_38":26,"_65":66,"_143":180,"_67":24,"_147":-5,"_172":181,"_17":182},{"_32":165,"_13":166,"_63":167,"_42":-5,"_34":35,"_146":106,"_168":169,"_36":170,"_38":26,"_65":66,"_143":171,"_67":24,"_147":-5,"_172":173,"_17":174},"9ab51341-e783-4689-8e2e-02696f8a9ae7","review5.ts","d111b966-ac8a-11f1-a843-1607ee4eb77e","latest",true,["D",1788984763812],"const P=\"{\\n \\\"schema\\\": \\\"ABANDONED_TRANSPORT_LANE_ISOLATION_FROZEN_REVIEW_PACKET_V2\\\",\\n \\\"classification\\\": \\\"CANDIDATE_ONLY_SECOND_PARTY_REVIEW_PACKET\\\",\\n \\\"task\\\": \\\"BRAIN-VAL-NATIVE-ABANDONED-TRANSPORT-LANE-ISOLATION-SECOND-PARTY-REVIEW-V1-20260908\\\",\\n \\\"producer\\\": \\\"chat-unproven-gpt56sol-20260909-2158-bbn-r1-k4x9p2\\\",\\n \\\"current_production_executor\\\": {\\n \\\"bytes\\\": 43706,\\n \\\"sha256\\\": \\\"dc142fb629c3197d79f0a9f772b639169ec86598d7b65a7f08a1c8b7c77adf0f\\\"\\n },\\n \\\"candidate_base\\\": {\\n \\\"path\\\": \\\"val_native_executor_prod.ts\\\",\\n \\\"version\\\": 2262,\\n \\\"bytes\\\": 25168,\\n \\\"sha256\\\": \\\"5547fe98a5ae7bc59c212f5867bb1d386542b6114e3001d88c64e0aeb15d5d05\\\"\\n },\\n \\\"candidate\\\": {\\n \\\"bytes\\\": 26742,\\n \\\"sha256\\\": \\\"1c6b354bae0c5aecf55555343b3dc76638d1dcb8333d855ce987e6735e904c49\\\",\\n \\\"source\\\": \\\"import { sqlite } from \\\\\\\"https://esm.town/v/std/sqlite/main.ts\\\\\\\";\\\\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\\\\\\\";\\\\nconst WORKER=\\\\\\\"project-brain-val-native-v1\\\\\\\";\\\\nconst INSTANCE=\\\\\\\"val-native-epoch2\\\\\\\";\\\\nconst LEASE_SECONDS=180;\\\\nconst TRANSPORT_PAYLOAD_TIMEOUT_MAX=120;\\\\nfunction readOnlyTransportSql(alias:string){\\\\n return `(${alias}.op='brain' AND json_valid(${alias}.payload_json)=1\\\\n AND json_type(${alias}.payload_json,'$.args')='array'\\\\n AND json_array_length(json_extract(${alias}.payload_json,'$.args'))=1\\\\n AND json_extract(${alias}.payload_json,'$.args[0]') IN ('status','verify-chain','verify-claim-graph')\\\\n AND json_type(${alias}.payload_json,'$.timeout')='integer'\\\\n AND json_extract(${alias}.payload_json,'$.timeout') BETWEEN 1 AND ${TRANSPORT_PAYLOAD_TIMEOUT_MAX}\\\\n AND (SELECT COUNT(*) FROM json_each(${alias}.payload_json))=2)`;\\\\n}\\\\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}\\\\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,lease_instance_id=NULL,lease_attempt_id=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 activeMutationLeases(){\\\\n const ro=readOnlyTransportSql(\\\\\\\"j\\\\\\\");\\\\n const r:any=await sqlite.execute(`SELECT j.id,j.lease_owner,j.lease_instance_id,j.lease_attempt_id,j.lease_expires_at\\\\n FROM ${JOB_TABLE} j\\\\n WHERE j.state='LEASED' AND j.lease_expires_at>datetime('now')\\\\n AND NOT ${ro}\\\\n ORDER BY j.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}\\\\nfunction laneAwareLeaseSql(sql:string){\\\\n const needle=`AND NOT EXISTS(\\\\n SELECT 1 FROM ${JOB_TABLE} x\\\\n WHERE x.state='LEASED' AND x.lease_owner=? AND x.lease_expires_at > datetime('now')\\\\n )`;\\\\n if(sql.split(needle).length!==2)throw new Error(\\\\\\\"LANE_AWARE_LEASE_GATE_SHAPE_DRIFT\\\\\\\");\\\\n const readCandidate=readOnlyTransportSql(\\\\\\\"j\\\\\\\");\\\\n const readActive=readOnlyTransportSql(\\\\\\\"x\\\\\\\");\\\\n return sql.replace(needle,`AND (\\\\n ${readCandidate}\\\\n OR NOT EXISTS(\\\\n SELECT 1 FROM ${JOB_TABLE} x\\\\n WHERE x.state='LEASED' AND x.lease_owner=? AND x.lease_expires_at > datetime('now')\\\\n AND NOT ${readActive}\\\\n )\\\\n )`);\\\\n}\\\\nasync function leaseOne(){\\\\n const gate=await admit();if(!gate.ok)return {kind:\\\\\\\"fenced\\\\\\\",gate} as const;\\\\n await recoverExpiredTransport();\\\\n const activeMutations=await activeMutationLeases();\\\\n if(activeMutations.length>1)return {kind:\\\\\\\"conflict\\\\\\\",active:activeMutations} 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:laneAwareLeaseSql(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;\\\\n if(!j){\\\\n if(activeMutations.length===1)return {kind:\\\\\\\"busy_mutation\\\\\\\",active:activeMutations[0]} as const;\\\\n return {kind:\\\\\\\"empty\\\\\\\"} as const;\\\\n }\\\\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} as const;\\\\n}\\\\nasync function finish(job:any,epoch:number,ok:boolean,value:any){\\\\n const gate=await admit();\\\\n if(!gate.ok||Number(gate.epoch)!==epoch){\\\\n return {ok:false,reason:\\\\\\\"CONTROL_PLANE_RESULT_FENCED\\\\\\\",authority:gate.authority??null};\\\\n }\\\\n const result=ok?legacyEnvelope(value):null;\\\\n const error=ok?null:JSON.stringify(value);\\\\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,lease_instance_id=NULL,lease_attempt_id=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`,\\\\n args:[ok?\\\\\\\"COMPLETE\\\\\\\":\\\\\\\"FAILED\\\\\\\",result,error,job.id,WORKER,INSTANCE,job.lease_attempt_id,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:ok?\\\\\\\"COMPLETE\\\\\\\":\\\\\\\"FAILED\\\\\\\"};\\\\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;idatetime('now')\\\\n AND NOT {ro('x')}\\\\n ))\\\\n ORDER BY priority DESC, created_at, j.rowid LIMIT 1)\\\\n RETURNING id,transport_lease_generation,lease_attempt_id\\\\\\\"\\\\\\\"\\\\\\\"\\\\n r=db.execute(sql,(WORKER,INSTANCE,attempt,WORKER)).fetchone(); db.commit()\\\\n return dict(r) if r else None\\\\n\\\\ndef finish(db,id,attempt,generation):\\\\n r=db.execute(\\\\\\\"\\\\\\\"\\\\\\\"UPDATE jobs SET state='COMPLETE',result_json='{}',error_json=NULL,\\\\n lease_owner=NULL,lease_expires_at=NULL,lease_instance_id=NULL,lease_attempt_id=NULL,updated_at=datetime('now')\\\\n WHERE id=? AND state='LEASED' AND lease_owner=? AND lease_instance_id=? AND lease_attempt_id=?\\\\n AND transport_lease_generation=? AND lease_expires_at>datetime('now') RETURNING id,state\\\\\\\"\\\\\\\"\\\\\\\",\\\\n (id,WORKER,INSTANCE,attempt,generation)).fetchone(); db.commit()\\\\n return dict(r) if r else None\\\\n\\\\ndef recover(db):\\\\n ids=[r[\\\\\\\"id\\\\\\\"] for r in db.execute(\\\\\\\"\\\\\\\"\\\\\\\"SELECT id FROM jobs WHERE state='LEASED'\\\\n AND lease_expires_at IS NOT NULL AND lease_expires_at<=datetime('now')\\\\\\\"\\\\\\\"\\\\\\\")]\\\\n for id in ids:\\\\n db.execute(\\\\\\\"\\\\\\\"\\\\\\\"UPDATE jobs SET state='FAILED',result_json=NULL,\\\\n error_json=json_object('classification','TRANSPORT_LEASE_EXPIRED_OUTCOME_UNKNOWN_REQUIRES_CANONICAL_RECONCILIATION'),\\\\n lease_owner=NULL,lease_expires_at=NULL,lease_instance_id=NULL,lease_attempt_id=NULL\\\\n WHERE id=?\\\\\\\"\\\\\\\"\\\\\\\",(id,))\\\\n db.commit(); return ids\\\\n\\\\ndef active_mutations(db):\\\\n return [r[\\\\\\\"id\\\\\\\"] for r in db.execute(f\\\\\\\"\\\\\\\"\\\\\\\"SELECT id FROM jobs j WHERE state='LEASED'\\\\n AND lease_expires_at>datetime('now') AND NOT {ro('j')} ORDER BY id\\\\\\\"\\\\\\\"\\\\\\\")]\\\\n\\\\nT=[]\\\\ndef check(name,cond): T.append((name,bool(cond)))\\\\n\\\\n# mutation blocks mutation, not read\\\\ndb=setup(); add(db,\\\\\\\"m0\\\\\\\",\\\\\\\"commit\\\\\\\",\\\\\\\"LEASED\\\\\\\",owner=WORKER,expires=\\\\\\\"2099-01-01 00:00:00\\\\\\\",attempt=\\\\\\\"m0\\\\\\\",generation=1)\\\\nadd(db,\\\\\\\"m1\\\\\\\",\\\\\\\"claim\\\\\\\",priority=200); add(db,\\\\\\\"r1\\\\\\\",\\\\\\\"status\\\\\\\",priority=100)\\\\na=lease(db,\\\\\\\"a\\\\\\\"); b=lease(db,\\\\\\\"b\\\\\\\")\\\\ncheck(\\\\\\\"mutation_allows_read\\\\\\\",a and a[\\\\\\\"id\\\\\\\"]==\\\\\\\"r1\\\\\\\"); check(\\\\\\\"mutation_blocks_second_mutation\\\\\\\",b is None)\\\\n\\\\n# read blocks nothing\\\\ndb=setup(); add(db,\\\\\\\"r0\\\\\\\",\\\\\\\"verify-chain\\\\\\\",\\\\\\\"LEASED\\\\\\\",owner=WORKER,expires=\\\\\\\"2099-01-01 00:00:00\\\\\\\",attempt=\\\\\\\"r0\\\\\\\",generation=1)\\\\nadd(db,\\\\\\\"m1\\\\\\\",\\\\\\\"commit\\\\\\\",priority=200); add(db,\\\\\\\"r1\\\\\\\",\\\\\\\"status\\\\\\\",priority=100)\\\\na=lease(db,\\\\\\\"a\\\\\\\"); b=lease(db,\\\\\\\"b\\\\\\\")\\\\ncheck(\\\\\\\"read_does_not_block_mutation\\\\\\\",a and a[\\\\\\\"id\\\\\\\"]==\\\\\\\"m1\\\\\\\"); check(\\\\\\\"read_concurrency_after_mutation_lease\\\\\\\",b and b[\\\\\\\"id\\\\\\\"]==\\\\\\\"r1\\\\\\\")\\\\n\\\\n# exact attempt finish\\\\ndb=setup(); add(db,\\\\\\\"r\\\\\\\",\\\\\\\"status\\\\\\\"); a=lease(db,\\\\\\\"good\\\\\\\")\\\\ncheck(\\\\\\\"wrong_attempt_finish_rejected\\\\\\\",finish(db,\\\\\\\"r\\\\\\\",\\\\\\\"bad\\\\\\\",a[\\\\\\\"transport_lease_generation\\\\\\\"]) is None)\\\\ncheck(\\\\\\\"exact_attempt_finish_accepted\\\\\\\",finish(db,\\\\\\\"r\\\\\\\",\\\\\\\"good\\\\\\\",a[\\\\\\\"transport_lease_generation\\\\\\\"]) is not None)\\\\n\\\\n# expiry unknown and progress\\\\ndb=setup(); add(db,\\\\\\\"old\\\\\\\",\\\\\\\"commit\\\\\\\",\\\\\\\"LEASED\\\\\\\",owner=WORKER,expires=\\\\\\\"2000-01-01 00:00:00\\\\\\\",attempt=\\\\\\\"o\\\\\\\",generation=1); add(db,\\\\\\\"next\\\\\\\",\\\\\\\"claim\\\\\\\")\\\\nids=recover(db); old=db.execute(\\\\\\\"SELECT * FROM jobs WHERE id='old'\\\\\\\").fetchone(); nxt=lease(db,\\\\\\\"n\\\\\\\")\\\\ncheck(\\\\\\\"expired_mutation_unknown\\\\\\\", \\\\\\\"old\\\\\\\" in ids and old[\\\\\\\"state\\\\\\\"]==\\\\\\\"FAILED\\\\\\\" and \\\\\\\"OUTCOME_UNKNOWN\\\\\\\" in old[\\\\\\\"error_json\\\\\\\"])\\\\ncheck(\\\\\\\"progress_after_expiry\\\\\\\",nxt and nxt[\\\\\\\"id\\\\\\\"]==\\\\\\\"next\\\\\\\")\\\\n\\\\n# terminal no replay\\\\ndb=setup(); add(db,\\\\\\\"r\\\\\\\",\\\\\\\"status\\\\\\\"); a=lease(db,\\\\\\\"a\\\\\\\"); finish(db,\\\\\\\"r\\\\\\\",\\\\\\\"a\\\\\\\",a[\\\\\\\"transport_lease_generation\\\\\\\"])\\\\ncheck(\\\\\\\"terminal_not_replayed\\\\\\\",lease(db,\\\\\\\"b\\\\\\\") is None)\\\\n\\\\n# malformed fail closed for mutation but not reads\\\\ndb=setup(); add(db,\\\\\\\"bad\\\\\\\",\\\\\\\"status\\\\\\\",\\\\\\\"LEASED\\\\\\\",owner=WORKER,expires=\\\\\\\"2099-01-01 00:00:00\\\\\\\",attempt=\\\\\\\"x\\\\\\\",generation=1,payload_json=payload(\\\\\\\"status\\\\\\\",extra=True))\\\\nadd(db,\\\\\\\"m\\\\\\\",\\\\\\\"claim\\\\\\\",priority=200); add(db,\\\\\\\"r\\\\\\\",\\\\\\\"verify-claim-graph\\\\\\\",priority=100)\\\\ncheck(\\\\\\\"malformed_active_is_mutation_class\\\\\\\",active_mutations(db)==[\\\\\\\"bad\\\\\\\"])\\\\na=lease(db,\\\\\\\"r1\\\\\\\"); b=lease(db,\\\\\\\"m1\\\\\\\")\\\\ncheck(\\\\\\\"malformed_active_allows_closed_read\\\\\\\",a and a[\\\\\\\"id\\\\\\\"]==\\\\\\\"r\\\\\\\")\\\\ncheck(\\\\\\\"malformed_active_blocks_mutation\\\\\\\",b is None)\\\\n\\\\n# lanes\\\\ndb=setup(); add(db,\\\\\\\"m1\\\\\\\",\\\\\\\"commit\\\\\\\",priority=200); add(db,\\\\\\\"m2\\\\\\\",\\\\\\\"claim\\\\\\\",priority=100)\\\\na=lease(db,\\\\\\\"1\\\\\\\"); b=lease(db,\\\\\\\"2\\\\\\\")\\\\ncheck(\\\\\\\"single_flight_mutation\\\\\\\",a and a[\\\\\\\"id\\\\\\\"]==\\\\\\\"m1\\\\\\\" and b is None)\\\\ndb=setup(); add(db,\\\\\\\"r1\\\\\\\",\\\\\\\"status\\\\\\\",priority=200); add(db,\\\\\\\"r2\\\\\\\",\\\\\\\"verify-chain\\\\\\\",priority=100)\\\\na=lease(db,\\\\\\\"1\\\\\\\"); b=lease(db,\\\\\\\"2\\\\\\\")\\\\ncheck(\\\\\\\"concurrent_reads\\\\\\\",a and b and {a[\\\\\\\"id\\\\\\\"],b[\\\\\\\"id\\\\\\\"]}=={\\\\\\\"r1\\\\\\\",\\\\\\\"r2\\\\\\\"})\\\\n\\\\nresult={\\\\\\\"schema\\\\\\\":\\\\\\\"ABANDONED_TRANSPORT_LANE_ISOLATION_HARNESS_V2\\\\\\\",\\\\\\\"pass\\\\\\\":all(v for _,v in T),\\\\n \\\\\\\"test_count\\\\\\\":len(T),\\\\\\\"failed\\\\\\\":[n for n,v in T if not v],\\\\n \\\\\\\"tests\\\\\\\":[{\\\\\\\"name\\\\\\\":n,\\\\\\\"pass\\\\\\\":v} for n,v in T]}\\\\nprint(json.dumps(result,separators=(\\\\\\\",\\\\\\\",\\\\\\\":\\\\\\\")))\\\\n\\\"\\n },\\n \\\"reconstruction_proof\\\": {\\n \\\"bytes\\\": 656,\\n \\\"sha256\\\": \\\"d80d0dfcbf73de788e3aa922b4e4c49df4d61d66786cd89b90aa4000adb759a4\\\"\\n },\\n \\\"identity_match_to_execution_receipt\\\": true\\n },\\n \\\"execution_receipt\\\": {\\n \\\"bytes\\\": 1817,\\n \\\"sha256\\\": \\\"4f44a4a46997c065c05626d3a6c539203b32ca84d618689f42c80bbd40ee4ee4\\\",\\n \\\"content\\\": {\\n \\\"schema\\\": \\\"ABANDONED_TRANSPORT_LANE_ISOLATION_HARNESS_EXECUTION_RECEIPT_V2\\\",\\n \\\"classification\\\": \\\"LOCAL_ISOLATED_EXECUTION_EVIDENCE_CANDIDATE_NONAUTHORITY\\\",\\n \\\"harness_bytes\\\": 6734,\\n \\\"harness_sha256\\\": \\\"b7ea9fe9410234d5f7ae19549188410e057f6de768d41084946d8f941cccedc0\\\",\\n \\\"interpreter\\\": \\\"CPython sqlite3 in-memory\\\",\\n \\\"exit_code\\\": 0,\\n \\\"stdout_json\\\": {\\n \\\"schema\\\": \\\"ABANDONED_TRANSPORT_LANE_ISOLATION_HARNESS_V2\\\",\\n \\\"pass\\\": true,\\n \\\"test_count\\\": 14,\\n \\\"failed\\\": [],\\n \\\"tests\\\": [\\n {\\n \\\"name\\\": \\\"mutation_allows_read\\\",\\n \\\"pass\\\": true\\n },\\n {\\n \\\"name\\\": \\\"mutation_blocks_second_mutation\\\",\\n \\\"pass\\\": true\\n },\\n {\\n \\\"name\\\": \\\"read_does_not_block_mutation\\\",\\n \\\"pass\\\": true\\n },\\n {\\n \\\"name\\\": \\\"read_concurrency_after_mutation_lease\\\",\\n \\\"pass\\\": true\\n },\\n {\\n \\\"name\\\": \\\"wrong_attempt_finish_rejected\\\",\\n \\\"pass\\\": true\\n },\\n {\\n \\\"name\\\": \\\"exact_attempt_finish_accepted\\\",\\n \\\"pass\\\": true\\n },\\n {\\n \\\"name\\\": \\\"expired_mutation_unknown\\\",\\n \\\"pass\\\": true\\n },\\n {\\n \\\"name\\\": \\\"progress_after_expiry\\\",\\n \\\"pass\\\": true\\n },\\n {\\n \\\"name\\\": \\\"terminal_not_replayed\\\",\\n \\\"pass\\\": true\\n },\\n {\\n \\\"name\\\": \\\"malformed_active_is_mutation_class\\\",\\n \\\"pass\\\": true\\n },\\n {\\n \\\"name\\\": \\\"malformed_active_allows_closed_read\\\",\\n \\\"pass\\\": true\\n },\\n {\\n \\\"name\\\": \\\"malformed_active_blocks_mutation\\\",\\n \\\"pass\\\": true\\n },\\n {\\n \\\"name\\\": \\\"single_flight_mutation\\\",\\n \\\"pass\\\": true\\n },\\n {\\n \\\"name\\\": \\\"concurrent_reads\\\",\\n \\\"pass\\\": true\\n }\\n ]\\n },\\n \\\"production_mutation\\\": false,\\n \\\"direct_sprites_calls\\\": 0,\\n \\\"human_authority_approval\\\": false,\\n \\\"p_real_increment\\\": 0\\n }\\n },\\n \\\"explicit_invariants\\\": [\\n \\\"at most one active mutation transport lease\\\",\\n \\\"exact closed-schema status/verify-chain/verify-claim-graph may coexist with active mutation and with each other\\\",\\n \\\"malformed or unknown active transport payload is mutation-class fail-closed\\\",\\n \\\"preserve exact-attempt result fencing\\\",\\n \\\"preserve expired mutation UNKNOWN_OUTCOME semantics\\\",\\n \\\"terminal jobs are never replayed\\\",\\n \\\"PREPARED_READ_ONLY admits only exact read-only commands\\\",\\n \\\"reconcileExactLeaseAttemptR2 cannot convert ambiguous acquisition into unsafe progress\\\",\\n \\\"transformed lease SQL must remain placeholder-compatible with leaseOneSql\\\",\\n \\\"no duplicate canonical mutation execution\\\"\\n ],\\n \\\"required_attacks\\\": [\\n \\\"mutation single-flight\\\",\\n \\\"read/mutation lane arbitration\\\",\\n \\\"malformed payload classification\\\",\\n \\\"exact-attempt finish fencing\\\",\\n \\\"expired mutation UNKNOWN_OUTCOME behavior\\\",\\n \\\"replay\\\",\\n \\\"PREPARED_READ_ONLY semantics\\\",\\n \\\"reconcileExactLeaseAttemptR2 semantics\\\",\\n \\\"queue ordering\\\",\\n \\\"transformed lease SQL placeholder compatibility\\\",\\n \\\"harness/receipt identity mismatch\\\"\\n ],\\n \\\"authority_effects\\\": {\\n \\\"canonical_mutation\\\": false,\\n \\\"production_mutation\\\": false,\\n \\\"p_real_increment\\\": 0,\\n \\\"independent_review_claimed\\\": false,\\n \\\"human_authority_approval\\\": false,\\n \\\"direct_sprites_calls\\\": 0,\\n \\\"additional_out_of_pocket_spend_usd\\\": 0\\n }\\n}\\n\",H=\"1645c8505e8f58e8f4427baff20b6707fc353e6a3f9c2650999bfb5518e9da83\";\nasync 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(\"\")}\nif(await sha(P)!==H)throw new Error(\"PACKET_HASH_MISMATCH\");\nconst model=\"poolside/laguna-s-2.1:free\",gateway=\"https://api.kilo.ai/api/gateway/chat/completions\";\nconst prompt=[\n\"Audit exact frozen packet SHA \"+H+\" as a distinct second-party correctness reviewer.\",\n\"Review every required_attacks item. A COUNTEREXAMPLE requires an ordered reachable state transition satisfying all source preconditions and a precise candidate construct.\",\n\"Do not use the previously corrupted harness; V2 includes a reconstructed exact source whose 6734-byte SHA matches the original execution receipt.\",\n\"Separate THREE judgments: candidate_internal_semantics, evidence_integrity, and integration_readiness_against_current_production.\",\n\"The candidate base hash differs from current production executor hash. Because packet intentionally contains only the current production hash, not its source, do not claim current-production rebase compatibility unless mechanically supported.\",\n\"PASS candidate semantics only if no reachable counterexample is found across mutation single-flight, lane arbitration, malformed classification, exact-attempt finish, expiry UNKNOWN_OUTCOME, replay, PREPARED_READ_ONLY, reconcileExactLeaseAttemptR2, queue ordering, and transformed SQL placeholder shape.\",\n\"Return ONLY compact JSON keys overall_verdict,candidate_internal_semantics,evidence_integrity,integration_readiness,attacks,reachable_counterexamples,minimum_fix. Keep attacks as an object mapping attack name to PASS/COUNTEREXAMPLE/NOT_PROVEN plus a short reason.\"\n].join(\"\\n\")+\"\\nPACKET:\\n\"+P;\nconst started=new Date().toISOString(),t=Date.now();\nconst resp=await fetch(gateway,{method:\"POST\",headers:{\"content-type\":\"application/json\"},body:JSON.stringify({model,messages:[{role:\"user\",content:prompt}],temperature:0,max_tokens:1800,stream:false,response_format:{type:\"json_object\"}})});\nconst raw=await resp.text(),finished=new Date().toISOString();\nif(!resp.ok){console.log(JSON.stringify({schema:\"ABANDONED_TRANSPORT_LANE_EXTERNAL_REVIEW_V3\",packet_sha256:H,model,started,finished,http_status:resp.status,error:raw.slice(0,1000)},null,2));}\nelse{const j=JSON.parse(raw),m=j?.choices?.[0]?.message??{};let review:any=null,rv=\"\";for(const c of [m.content,m.reasoning_content,m.reasoning,j?.choices?.[0]?.text]){if(typeof c!==\"string\"||!c.trim())continue;const a=c.indexOf(\"{\"),b=c.lastIndexOf(\"}\");if(a>=0&&b>=a){try{review=JSON.parse(c.slice(a,b+1));rv=c;break}catch{}}}\nconsole.log(JSON.stringify({schema:\"ABANDONED_TRANSPORT_LANE_EXTERNAL_REVIEW_V3\",packet_sha256:H,packet_hash_verified:true,model,returned_model:j?.model??null,provider_response_id:j?.id??null,started,finished,ms:Date.now()-t,http_status:resp.status,usage:j?.usage??null,reported_cost:j?.usage?.cost??null,review,raw_verdict:rv,raw_verdict_sha256:rv?await sha(rv):null},null,2));}","children",[],[166],"5945eb19-8c03-4e48-9812-252694a3e58c","review4.ts","bc386468-ac8a-11f1-be7a-1607ee4eb77e",4,["D",1788984728838],"const P=\"{\\n \\\"schema\\\": \\\"ABANDONED_TRANSPORT_LANE_ISOLATION_FROZEN_REVIEW_PACKET_V2\\\",\\n \\\"classification\\\": \\\"CANDIDATE_ONLY_SECOND_PARTY_REVIEW_PACKET\\\",\\n \\\"task\\\": \\\"BRAIN-VAL-NATIVE-ABANDONED-TRANSPORT-LANE-ISOLATION-SECOND-PARTY-REVIEW-V1-20260908\\\",\\n \\\"producer\\\": \\\"chat-unproven-gpt56sol-20260909-2158-bbn-r1-k4x9p2\\\",\\n \\\"current_production_executor\\\": {\\n \\\"bytes\\\": 43706,\\n \\\"sha256\\\": \\\"dc142fb629c3197d79f0a9f772b639169ec86598d7b65a7f08a1c8b7c77adf0f\\\"\\n },\\n \\\"candidate_base\\\": {\\n \\\"path\\\": \\\"val_native_executor_prod.ts\\\",\\n \\\"version\\\": 2262,\\n \\\"bytes\\\": 25168,\\n \\\"sha256\\\": \\\"5547fe98a5ae7bc59c212f5867bb1d386542b6114e3001d88c64e0aeb15d5d05\\\"\\n },\\n \\\"candidate\\\": {\\n \\\"bytes\\\": 26742,\\n \\\"sha256\\\": \\\"1c6b354bae0c5aecf55555343b3dc76638d1dcb8333d855ce987e6735e904c49\\\",\\n \\\"source\\\": \\\"import { sqlite } from \\\\\\\"https://esm.town/v/std/sqlite/main.ts\\\\\\\";\\\\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\\\\\\\";\\\\nconst WORKER=\\\\\\\"project-brain-val-native-v1\\\\\\\";\\\\nconst INSTANCE=\\\\\\\"val-native-epoch2\\\\\\\";\\\\nconst LEASE_SECONDS=180;\\\\nconst TRANSPORT_PAYLOAD_TIMEOUT_MAX=120;\\\\nfunction readOnlyTransportSql(alias:string){\\\\n return `(${alias}.op='brain' AND json_valid(${alias}.payload_json)=1\\\\n AND json_type(${alias}.payload_json,'$.args')='array'\\\\n AND json_array_length(json_extract(${alias}.payload_json,'$.args'))=1\\\\n AND json_extract(${alias}.payload_json,'$.args[0]') IN ('status','verify-chain','verify-claim-graph')\\\\n AND json_type(${alias}.payload_json,'$.timeout')='integer'\\\\n AND json_extract(${alias}.payload_json,'$.timeout') BETWEEN 1 AND ${TRANSPORT_PAYLOAD_TIMEOUT_MAX}\\\\n AND (SELECT COUNT(*) FROM json_each(${alias}.payload_json))=2)`;\\\\n}\\\\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}\\\\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,lease_instance_id=NULL,lease_attempt_id=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 activeMutationLeases(){\\\\n const ro=readOnlyTransportSql(\\\\\\\"j\\\\\\\");\\\\n const r:any=await sqlite.execute(`SELECT j.id,j.lease_owner,j.lease_instance_id,j.lease_attempt_id,j.lease_expires_at\\\\n FROM ${JOB_TABLE} j\\\\n WHERE j.state='LEASED' AND j.lease_expires_at>datetime('now')\\\\n AND NOT ${ro}\\\\n ORDER BY j.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}\\\\nfunction laneAwareLeaseSql(sql:string){\\\\n const needle=`AND NOT EXISTS(\\\\n SELECT 1 FROM ${JOB_TABLE} x\\\\n WHERE x.state='LEASED' AND x.lease_owner=? AND x.lease_expires_at > datetime('now')\\\\n )`;\\\\n if(sql.split(needle).length!==2)throw new Error(\\\\\\\"LANE_AWARE_LEASE_GATE_SHAPE_DRIFT\\\\\\\");\\\\n const readCandidate=readOnlyTransportSql(\\\\\\\"j\\\\\\\");\\\\n const readActive=readOnlyTransportSql(\\\\\\\"x\\\\\\\");\\\\n return sql.replace(needle,`AND (\\\\n ${readCandidate}\\\\n OR NOT EXISTS(\\\\n SELECT 1 FROM ${JOB_TABLE} x\\\\n WHERE x.state='LEASED' AND x.lease_owner=? AND x.lease_expires_at > datetime('now')\\\\n AND NOT ${readActive}\\\\n )\\\\n )`);\\\\n}\\\\nasync function leaseOne(){\\\\n const gate=await admit();if(!gate.ok)return {kind:\\\\\\\"fenced\\\\\\\",gate} as const;\\\\n await recoverExpiredTransport();\\\\n const activeMutations=await activeMutationLeases();\\\\n if(activeMutations.length>1)return {kind:\\\\\\\"conflict\\\\\\\",active:activeMutations} 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:laneAwareLeaseSql(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;\\\\n if(!j){\\\\n if(activeMutations.length===1)return {kind:\\\\\\\"busy_mutation\\\\\\\",active:activeMutations[0]} as const;\\\\n return {kind:\\\\\\\"empty\\\\\\\"} as const;\\\\n }\\\\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} as const;\\\\n}\\\\nasync function finish(job:any,epoch:number,ok:boolean,value:any){\\\\n const gate=await admit();\\\\n if(!gate.ok||Number(gate.epoch)!==epoch){\\\\n return {ok:false,reason:\\\\\\\"CONTROL_PLANE_RESULT_FENCED\\\\\\\",authority:gate.authority??null};\\\\n }\\\\n const result=ok?legacyEnvelope(value):null;\\\\n const error=ok?null:JSON.stringify(value);\\\\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,lease_instance_id=NULL,lease_attempt_id=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`,\\\\n args:[ok?\\\\\\\"COMPLETE\\\\\\\":\\\\\\\"FAILED\\\\\\\",result,error,job.id,WORKER,INSTANCE,job.lease_attempt_id,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:ok?\\\\\\\"COMPLETE\\\\\\\":\\\\\\\"FAILED\\\\\\\"};\\\\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;idatetime('now')\\\\n AND NOT {ro('x')}\\\\n ))\\\\n ORDER BY priority DESC, created_at, j.rowid LIMIT 1)\\\\n RETURNING id,transport_lease_generation,lease_attempt_id\\\\\\\"\\\\\\\"\\\\\\\"\\\\n r=db.execute(sql,(WORKER,INSTANCE,attempt,WORKER)).fetchone(); db.commit()\\\\n return dict(r) if r else None\\\\n\\\\ndef finish(db,id,attempt,generation):\\\\n r=db.execute(\\\\\\\"\\\\\\\"\\\\\\\"UPDATE jobs SET state='COMPLETE',result_json='{}',error_json=NULL,\\\\n lease_owner=NULL,lease_expires_at=NULL,lease_instance_id=NULL,lease_attempt_id=NULL,updated_at=datetime('now')\\\\n WHERE id=? AND state='LEASED' AND lease_owner=? AND lease_instance_id=? AND lease_attempt_id=?\\\\n AND transport_lease_generation=? AND lease_expires_at>datetime('now') RETURNING id,state\\\\\\\"\\\\\\\"\\\\\\\",\\\\n (id,WORKER,INSTANCE,attempt,generation)).fetchone(); db.commit()\\\\n return dict(r) if r else None\\\\n\\\\ndef recover(db):\\\\n ids=[r[\\\\\\\"id\\\\\\\"] for r in db.execute(\\\\\\\"\\\\\\\"\\\\\\\"SELECT id FROM jobs WHERE state='LEASED'\\\\n AND lease_expires_at IS NOT NULL AND lease_expires_at<=datetime('now')\\\\\\\"\\\\\\\"\\\\\\\")]\\\\n for id in ids:\\\\n db.execute(\\\\\\\"\\\\\\\"\\\\\\\"UPDATE jobs SET state='FAILED',result_json=NULL,\\\\n error_json=json_object('classification','TRANSPORT_LEASE_EXPIRED_OUTCOME_UNKNOWN_REQUIRES_CANONICAL_RECONCILIATION'),\\\\n lease_owner=NULL,lease_expires_at=NULL,lease_instance_id=NULL,lease_attempt_id=NULL\\\\n WHERE id=?\\\\\\\"\\\\\\\"\\\\\\\",(id,))\\\\n db.commit(); return ids\\\\n\\\\ndef active_mutations(db):\\\\n return [r[\\\\\\\"id\\\\\\\"] for r in db.execute(f\\\\\\\"\\\\\\\"\\\\\\\"SELECT id FROM jobs j WHERE state='LEASED'\\\\n AND lease_expires_at>datetime('now') AND NOT {ro('j')} ORDER BY id\\\\\\\"\\\\\\\"\\\\\\\")]\\\\n\\\\nT=[]\\\\ndef check(name,cond): T.append((name,bool(cond)))\\\\n\\\\n# mutation blocks mutation, not read\\\\ndb=setup(); add(db,\\\\\\\"m0\\\\\\\",\\\\\\\"commit\\\\\\\",\\\\\\\"LEASED\\\\\\\",owner=WORKER,expires=\\\\\\\"2099-01-01 00:00:00\\\\\\\",attempt=\\\\\\\"m0\\\\\\\",generation=1)\\\\nadd(db,\\\\\\\"m1\\\\\\\",\\\\\\\"claim\\\\\\\",priority=200); add(db,\\\\\\\"r1\\\\\\\",\\\\\\\"status\\\\\\\",priority=100)\\\\na=lease(db,\\\\\\\"a\\\\\\\"); b=lease(db,\\\\\\\"b\\\\\\\")\\\\ncheck(\\\\\\\"mutation_allows_read\\\\\\\",a and a[\\\\\\\"id\\\\\\\"]==\\\\\\\"r1\\\\\\\"); check(\\\\\\\"mutation_blocks_second_mutation\\\\\\\",b is None)\\\\n\\\\n# read blocks nothing\\\\ndb=setup(); add(db,\\\\\\\"r0\\\\\\\",\\\\\\\"verify-chain\\\\\\\",\\\\\\\"LEASED\\\\\\\",owner=WORKER,expires=\\\\\\\"2099-01-01 00:00:00\\\\\\\",attempt=\\\\\\\"r0\\\\\\\",generation=1)\\\\nadd(db,\\\\\\\"m1\\\\\\\",\\\\\\\"commit\\\\\\\",priority=200); add(db,\\\\\\\"r1\\\\\\\",\\\\\\\"status\\\\\\\",priority=100)\\\\na=lease(db,\\\\\\\"a\\\\\\\"); b=lease(db,\\\\\\\"b\\\\\\\")\\\\ncheck(\\\\\\\"read_does_not_block_mutation\\\\\\\",a and a[\\\\\\\"id\\\\\\\"]==\\\\\\\"m1\\\\\\\"); check(\\\\\\\"read_concurrency_after_mutation_lease\\\\\\\",b and b[\\\\\\\"id\\\\\\\"]==\\\\\\\"r1\\\\\\\")\\\\n\\\\n# exact attempt finish\\\\ndb=setup(); add(db,\\\\\\\"r\\\\\\\",\\\\\\\"status\\\\\\\"); a=lease(db,\\\\\\\"good\\\\\\\")\\\\ncheck(\\\\\\\"wrong_attempt_finish_rejected\\\\\\\",finish(db,\\\\\\\"r\\\\\\\",\\\\\\\"bad\\\\\\\",a[\\\\\\\"transport_lease_generation\\\\\\\"]) is None)\\\\ncheck(\\\\\\\"exact_attempt_finish_accepted\\\\\\\",finish(db,\\\\\\\"r\\\\\\\",\\\\\\\"good\\\\\\\",a[\\\\\\\"transport_lease_generation\\\\\\\"]) is not None)\\\\n\\\\n# expiry unknown and progress\\\\ndb=setup(); add(db,\\\\\\\"old\\\\\\\",\\\\\\\"commit\\\\\\\",\\\\\\\"LEASED\\\\\\\",owner=WORKER,expires=\\\\\\\"2000-01-01 00:00:00\\\\\\\",attempt=\\\\\\\"o\\\\\\\",generation=1); add(db,\\\\\\\"next\\\\\\\",\\\\\\\"claim\\\\\\\")\\\\nids=recover(db); old=db.execute(\\\\\\\"SELECT * FROM jobs WHERE id='old'\\\\\\\").fetchone(); nxt=lease(db,\\\\\\\"n\\\\\\\")\\\\ncheck(\\\\\\\"expired_mutation_unknown\\\\\\\", \\\\\\\"old\\\\\\\" in ids and old[\\\\\\\"state\\\\\\\"]==\\\\\\\"FAILED\\\\\\\" and \\\\\\\"OUTCOME_UNKNOWN\\\\\\\" in old[\\\\\\\"error_json\\\\\\\"])\\\\ncheck(\\\\\\\"progress_after_expiry\\\\\\\",nxt and nxt[\\\\\\\"id\\\\\\\"]==\\\\\\\"next\\\\\\\")\\\\n\\\\n# terminal no replay\\\\ndb=setup(); add(db,\\\\\\\"r\\\\\\\",\\\\\\\"status\\\\\\\"); a=lease(db,\\\\\\\"a\\\\\\\"); finish(db,\\\\\\\"r\\\\\\\",\\\\\\\"a\\\\\\\",a[\\\\\\\"transport_lease_generation\\\\\\\"])\\\\ncheck(\\\\\\\"terminal_not_replayed\\\\\\\",lease(db,\\\\\\\"b\\\\\\\") is None)\\\\n\\\\n# malformed fail closed for mutation but not reads\\\\ndb=setup(); add(db,\\\\\\\"bad\\\\\\\",\\\\\\\"status\\\\\\\",\\\\\\\"LEASED\\\\\\\",owner=WORKER,expires=\\\\\\\"2099-01-01 00:00:00\\\\\\\",attempt=\\\\\\\"x\\\\\\\",generation=1,payload_json=payload(\\\\\\\"status\\\\\\\",extra=True))\\\\nadd(db,\\\\\\\"m\\\\\\\",\\\\\\\"claim\\\\\\\",priority=200); add(db,\\\\\\\"r\\\\\\\",\\\\\\\"verify-claim-graph\\\\\\\",priority=100)\\\\ncheck(\\\\\\\"malformed_active_is_mutation_class\\\\\\\",active_mutations(db)==[\\\\\\\"bad\\\\\\\"])\\\\na=lease(db,\\\\\\\"r1\\\\\\\"); b=lease(db,\\\\\\\"m1\\\\\\\")\\\\ncheck(\\\\\\\"malformed_active_allows_closed_read\\\\\\\",a and a[\\\\\\\"id\\\\\\\"]==\\\\\\\"r\\\\\\\")\\\\ncheck(\\\\\\\"malformed_active_blocks_mutation\\\\\\\",b is None)\\\\n\\\\n# lanes\\\\ndb=setup(); add(db,\\\\\\\"m1\\\\\\\",\\\\\\\"commit\\\\\\\",priority=200); add(db,\\\\\\\"m2\\\\\\\",\\\\\\\"claim\\\\\\\",priority=100)\\\\na=lease(db,\\\\\\\"1\\\\\\\"); b=lease(db,\\\\\\\"2\\\\\\\")\\\\ncheck(\\\\\\\"single_flight_mutation\\\\\\\",a and a[\\\\\\\"id\\\\\\\"]==\\\\\\\"m1\\\\\\\" and b is None)\\\\ndb=setup(); add(db,\\\\\\\"r1\\\\\\\",\\\\\\\"status\\\\\\\",priority=200); add(db,\\\\\\\"r2\\\\\\\",\\\\\\\"verify-chain\\\\\\\",priority=100)\\\\na=lease(db,\\\\\\\"1\\\\\\\"); b=lease(db,\\\\\\\"2\\\\\\\")\\\\ncheck(\\\\\\\"concurrent_reads\\\\\\\",a and b and {a[\\\\\\\"id\\\\\\\"],b[\\\\\\\"id\\\\\\\"]}=={\\\\\\\"r1\\\\\\\",\\\\\\\"r2\\\\\\\"})\\\\n\\\\nresult={\\\\\\\"schema\\\\\\\":\\\\\\\"ABANDONED_TRANSPORT_LANE_ISOLATION_HARNESS_V2\\\\\\\",\\\\\\\"pass\\\\\\\":all(v for _,v in T),\\\\n \\\\\\\"test_count\\\\\\\":len(T),\\\\\\\"failed\\\\\\\":[n for n,v in T if not v],\\\\n \\\\\\\"tests\\\\\\\":[{\\\\\\\"name\\\\\\\":n,\\\\\\\"pass\\\\\\\":v} for n,v in T]}\\\\nprint(json.dumps(result,separators=(\\\\\\\",\\\\\\\",\\\\\\\":\\\\\\\")))\\\\n\\\"\\n },\\n \\\"reconstruction_proof\\\": {\\n \\\"bytes\\\": 656,\\n \\\"sha256\\\": \\\"d80d0dfcbf73de788e3aa922b4e4c49df4d61d66786cd89b90aa4000adb759a4\\\"\\n },\\n \\\"identity_match_to_execution_receipt\\\": true\\n },\\n \\\"execution_receipt\\\": {\\n \\\"bytes\\\": 1817,\\n \\\"sha256\\\": \\\"4f44a4a46997c065c05626d3a6c539203b32ca84d618689f42c80bbd40ee4ee4\\\",\\n \\\"content\\\": {\\n \\\"schema\\\": \\\"ABANDONED_TRANSPORT_LANE_ISOLATION_HARNESS_EXECUTION_RECEIPT_V2\\\",\\n \\\"classification\\\": \\\"LOCAL_ISOLATED_EXECUTION_EVIDENCE_CANDIDATE_NONAUTHORITY\\\",\\n \\\"harness_bytes\\\": 6734,\\n \\\"harness_sha256\\\": \\\"b7ea9fe9410234d5f7ae19549188410e057f6de768d41084946d8f941cccedc0\\\",\\n \\\"interpreter\\\": \\\"CPython sqlite3 in-memory\\\",\\n \\\"exit_code\\\": 0,\\n \\\"stdout_json\\\": {\\n \\\"schema\\\": \\\"ABANDONED_TRANSPORT_LANE_ISOLATION_HARNESS_V2\\\",\\n \\\"pass\\\": true,\\n \\\"test_count\\\": 14,\\n \\\"failed\\\": [],\\n \\\"tests\\\": [\\n {\\n \\\"name\\\": \\\"mutation_allows_read\\\",\\n \\\"pass\\\": true\\n },\\n {\\n \\\"name\\\": \\\"mutation_blocks_second_mutation\\\",\\n \\\"pass\\\": true\\n },\\n {\\n \\\"name\\\": \\\"read_does_not_block_mutation\\\",\\n \\\"pass\\\": true\\n },\\n {\\n \\\"name\\\": \\\"read_concurrency_after_mutation_lease\\\",\\n \\\"pass\\\": true\\n },\\n {\\n \\\"name\\\": \\\"wrong_attempt_finish_rejected\\\",\\n \\\"pass\\\": true\\n },\\n {\\n \\\"name\\\": \\\"exact_attempt_finish_accepted\\\",\\n \\\"pass\\\": true\\n },\\n {\\n \\\"name\\\": \\\"expired_mutation_unknown\\\",\\n \\\"pass\\\": true\\n },\\n {\\n \\\"name\\\": \\\"progress_after_expiry\\\",\\n \\\"pass\\\": true\\n },\\n {\\n \\\"name\\\": \\\"terminal_not_replayed\\\",\\n \\\"pass\\\": true\\n },\\n {\\n \\\"name\\\": \\\"malformed_active_is_mutation_class\\\",\\n \\\"pass\\\": true\\n },\\n {\\n \\\"name\\\": \\\"malformed_active_allows_closed_read\\\",\\n \\\"pass\\\": true\\n },\\n {\\n \\\"name\\\": \\\"malformed_active_blocks_mutation\\\",\\n \\\"pass\\\": true\\n },\\n {\\n \\\"name\\\": \\\"single_flight_mutation\\\",\\n \\\"pass\\\": true\\n },\\n {\\n \\\"name\\\": \\\"concurrent_reads\\\",\\n \\\"pass\\\": true\\n }\\n ]\\n },\\n \\\"production_mutation\\\": false,\\n \\\"direct_sprites_calls\\\": 0,\\n \\\"human_authority_approval\\\": false,\\n \\\"p_real_increment\\\": 0\\n }\\n },\\n \\\"explicit_invariants\\\": [\\n \\\"at most one active mutation transport lease\\\",\\n \\\"exact closed-schema status/verify-chain/verify-claim-graph may coexist with active mutation and with each other\\\",\\n \\\"malformed or unknown active transport payload is mutation-class fail-closed\\\",\\n \\\"preserve exact-attempt result fencing\\\",\\n \\\"preserve expired mutation UNKNOWN_OUTCOME semantics\\\",\\n \\\"terminal jobs are never replayed\\\",\\n \\\"PREPARED_READ_ONLY admits only exact read-only commands\\\",\\n \\\"reconcileExactLeaseAttemptR2 cannot convert ambiguous acquisition into unsafe progress\\\",\\n \\\"transformed lease SQL must remain placeholder-compatible with leaseOneSql\\\",\\n \\\"no duplicate canonical mutation execution\\\"\\n ],\\n \\\"required_attacks\\\": [\\n \\\"mutation single-flight\\\",\\n \\\"read/mutation lane arbitration\\\",\\n \\\"malformed payload classification\\\",\\n \\\"exact-attempt finish fencing\\\",\\n \\\"expired mutation UNKNOWN_OUTCOME behavior\\\",\\n \\\"replay\\\",\\n \\\"PREPARED_READ_ONLY semantics\\\",\\n \\\"reconcileExactLeaseAttemptR2 semantics\\\",\\n \\\"queue ordering\\\",\\n \\\"transformed lease SQL placeholder compatibility\\\",\\n \\\"harness/receipt identity mismatch\\\"\\n ],\\n \\\"authority_effects\\\": {\\n \\\"canonical_mutation\\\": false,\\n \\\"production_mutation\\\": false,\\n \\\"p_real_increment\\\": 0,\\n \\\"independent_review_claimed\\\": false,\\n \\\"human_authority_approval\\\": false,\\n \\\"direct_sprites_calls\\\": 0,\\n \\\"additional_out_of_pocket_spend_usd\\\": 0\\n }\\n}\\n\",H=\"1645c8505e8f58e8f4427baff20b6707fc353e6a3f9c2650999bfb5518e9da83\";\nasync 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(\"\")}\nif(await sha(P)!==H)throw new Error(\"PACKET_HASH_MISMATCH\");\nconst model=\"cohere/north-mini-code:free\",gateway=\"https://api.kilo.ai/api/gateway/chat/completions\";\nconst prompt=[\n\"Audit exact frozen packet SHA \"+H+\" as a distinct second-party correctness reviewer.\",\n\"Review every required_attacks item. A COUNTEREXAMPLE requires an ordered reachable state transition satisfying all source preconditions and a precise candidate construct.\",\n\"Do not use the previously corrupted harness; V2 includes a reconstructed exact source whose 6734-byte SHA matches the original execution receipt.\",\n\"Separate THREE judgments: candidate_internal_semantics, evidence_integrity, and integration_readiness_against_current_production.\",\n\"The candidate base hash differs from current production executor hash. Because packet intentionally contains only the current production hash, not its source, do not claim current-production rebase compatibility unless mechanically supported.\",\n\"PASS candidate semantics only if no reachable counterexample is found across mutation single-flight, lane arbitration, malformed classification, exact-attempt finish, expiry UNKNOWN_OUTCOME, replay, PREPARED_READ_ONLY, reconcileExactLeaseAttemptR2, queue ordering, and transformed SQL placeholder shape.\",\n\"Return ONLY JSON keys overall_verdict,candidate_internal_semantics,evidence_integrity,integration_readiness,attacks,reachable_counterexamples,minimum_fix.\"\n].join(\"\\n\")+\"\\nPACKET:\\n\"+P;\nconst started=new Date().toISOString(),t=Date.now();\nconst resp=await fetch(gateway,{method:\"POST\",headers:{\"content-type\":\"application/json\"},body:JSON.stringify({model,messages:[{role:\"user\",content:prompt}],temperature:0,max_tokens:2600,stream:false,response_format:{type:\"json_object\"}})});\nconst raw=await resp.text(),finished=new Date().toISOString();\nif(!resp.ok){console.log(JSON.stringify({schema:\"ABANDONED_TRANSPORT_LANE_EXTERNAL_REVIEW_V4\",packet_sha256:H,model,started,finished,http_status:resp.status,error:raw.slice(0,1000)},null,2));}\nelse{const j=JSON.parse(raw),m=j?.choices?.[0]?.message??{};let review:any=null,rv=\"\";for(const c of [m.content,m.reasoning_content,m.reasoning,j?.choices?.[0]?.text]){if(typeof c!==\"string\"||!c.trim())continue;const a=c.indexOf(\"{\"),b=c.lastIndexOf(\"}\");if(a>=0&&b>=a){try{review=JSON.parse(c.slice(a,b+1));rv=c;break}catch{}}}\nconsole.log(JSON.stringify({schema:\"ABANDONED_TRANSPORT_LANE_EXTERNAL_REVIEW_V3\",packet_sha256:H,packet_hash_verified:true,model,returned_model:j?.model??null,provider_response_id:j?.id??null,started,finished,ms:Date.now()-t,http_status:resp.status,usage:j?.usage??null,reported_cost:j?.usage?.cost??null,review,raw_verdict:rv,raw_verdict_sha256:rv?await sha(rv):null},null,2));}",[],[176],["D",1788984671706],[],[18],"559f0734-1de8-4690-99cd-68e8fab5fcef","review2.ts","503be6d6-ac8a-11f1-b28f-1607ee4eb77e",2,["D",1788984547630],"const P=\"{\\n \\\"schema\\\": \\\"ABANDONED_TRANSPORT_LANE_ISOLATION_FROZEN_REVIEW_PACKET_V1\\\",\\n \\\"classification\\\": \\\"CANDIDATE_ONLY_SECOND_PARTY_REVIEW_PACKET\\\",\\n \\\"task\\\": \\\"BRAIN-VAL-NATIVE-ABANDONED-TRANSPORT-LANE-ISOLATION-SECOND-PARTY-REVIEW-V1-20260908\\\",\\n \\\"producer\\\": \\\"chat-unproven-gpt56sol-20260909-2158-bbn-r1-k4x9p2\\\",\\n \\\"current_production_executor\\\": {\\n \\\"bytes\\\": 43706,\\n \\\"sha256\\\": \\\"dc142fb629c3197d79f0a9f772b639169ec86598d7b65a7f08a1c8b7c77adf0f\\\"\\n },\\n \\\"candidate_base\\\": {\\n \\\"path\\\": \\\"val_native_executor_prod.ts\\\",\\n \\\"version\\\": 2262,\\n \\\"bytes\\\": 25168,\\n \\\"sha256\\\": \\\"5547fe98a5ae7bc59c212f5867bb1d386542b6114e3001d88c64e0aeb15d5d05\\\"\\n },\\n \\\"candidate\\\": {\\n \\\"bytes\\\": 26742,\\n \\\"sha256\\\": \\\"1c6b354bae0c5aecf55555343b3dc76638d1dcb8333d855ce987e6735e904c49\\\",\\n \\\"source\\\": \\\"import { sqlite } from \\\\\\\"https://esm.town/v/std/sqlite/main.ts\\\\\\\";\\\\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\\\\\\\";\\\\nconst WORKER=\\\\\\\"project-brain-val-native-v1\\\\\\\";\\\\nconst INSTANCE=\\\\\\\"val-native-epoch2\\\\\\\";\\\\nconst LEASE_SECONDS=180;\\\\nconst TRANSPORT_PAYLOAD_TIMEOUT_MAX=120;\\\\nfunction readOnlyTransportSql(alias:string){\\\\n return `(${alias}.op='brain' AND json_valid(${alias}.payload_json)=1\\\\n AND json_type(${alias}.payload_json,'$.args')='array'\\\\n AND json_array_length(json_extract(${alias}.payload_json,'$.args'))=1\\\\n AND json_extract(${alias}.payload_json,'$.args[0]') IN ('status','verify-chain','verify-claim-graph')\\\\n AND json_type(${alias}.payload_json,'$.timeout')='integer'\\\\n AND json_extract(${alias}.payload_json,'$.timeout') BETWEEN 1 AND ${TRANSPORT_PAYLOAD_TIMEOUT_MAX}\\\\n AND (SELECT COUNT(*) FROM json_each(${alias}.payload_json))=2)`;\\\\n}\\\\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}\\\\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,lease_instance_id=NULL,lease_attempt_id=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 activeMutationLeases(){\\\\n const ro=readOnlyTransportSql(\\\\\\\"j\\\\\\\");\\\\n const r:any=await sqlite.execute(`SELECT j.id,j.lease_owner,j.lease_instance_id,j.lease_attempt_id,j.lease_expires_at\\\\n FROM ${JOB_TABLE} j\\\\n WHERE j.state='LEASED' AND j.lease_expires_at>datetime('now')\\\\n AND NOT ${ro}\\\\n ORDER BY j.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}\\\\nfunction laneAwareLeaseSql(sql:string){\\\\n const needle=`AND NOT EXISTS(\\\\n SELECT 1 FROM ${JOB_TABLE} x\\\\n WHERE x.state='LEASED' AND x.lease_owner=? AND x.lease_expires_at > datetime('now')\\\\n )`;\\\\n if(sql.split(needle).length!==2)throw new Error(\\\\\\\"LANE_AWARE_LEASE_GATE_SHAPE_DRIFT\\\\\\\");\\\\n const readCandidate=readOnlyTransportSql(\\\\\\\"j\\\\\\\");\\\\n const readActive=readOnlyTransportSql(\\\\\\\"x\\\\\\\");\\\\n return sql.replace(needle,`AND (\\\\n ${readCandidate}\\\\n OR NOT EXISTS(\\\\n SELECT 1 FROM ${JOB_TABLE} x\\\\n WHERE x.state='LEASED' AND x.lease_owner=? AND x.lease_expires_at > datetime('now')\\\\n AND NOT ${readActive}\\\\n )\\\\n )`);\\\\n}\\\\nasync function leaseOne(){\\\\n const gate=await admit();if(!gate.ok)return {kind:\\\\\\\"fenced\\\\\\\",gate} as const;\\\\n await recoverExpiredTransport();\\\\n const activeMutations=await activeMutationLeases();\\\\n if(activeMutations.length>1)return {kind:\\\\\\\"conflict\\\\\\\",active:activeMutations} 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:laneAwareLeaseSql(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;\\\\n if(!j){\\\\n if(activeMutations.length===1)return {kind:\\\\\\\"busy_mutation\\\\\\\",active:activeMutations[0]} as const;\\\\n return {kind:\\\\\\\"empty\\\\\\\"} as const;\\\\n }\\\\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} as const;\\\\n}\\\\nasync function finish(job:any,epoch:number,ok:boolean,value:any){\\\\n const gate=await admit();\\\\n if(!gate.ok||Number(gate.epoch)!==epoch){\\\\n return {ok:false,reason:\\\\\\\"CONTROL_PLANE_RESULT_FENCED\\\\\\\",authority:gate.authority??null};\\\\n }\\\\n const result=ok?legacyEnvelope(value):null;\\\\n const error=ok?null:JSON.stringify(value);\\\\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,lease_instance_id=NULL,lease_attempt_id=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`,\\\\n args:[ok?\\\\\\\"COMPLETE\\\\\\\":\\\\\\\"FAILED\\\\\\\",result,error,job.id,WORKER,INSTANCE,job.lease_attempt_id,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:ok?\\\\\\\"COMPLETE\\\\\\\":\\\\\\\"FAILED\\\\\\\"};\\\\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;idatetime('now')\\\\n AND NOT {ro('x')}\\\\n ))\\\\n ORDER BY priority DESC, created_at, j.rowid LIMIT 1)\\\\n RETURNING id,transport_lease_generation,lease_attempt_id\\\\\\\"\\\\\\\"\\\\\\\"\\\\n r=db.execute(sql,(WORKER,INSTANCE,attempt,WORKER)).fetchone(); db.commit()\\\\n return dict(r) if r else None\\\\n\\\\ndef finish(db,id,attempt,generation):\\\\n r=db.execute(\\\\\\\"\\\\\\\"\\\\\\\"UPDATE jobs SET state='COMPLETE',result_json='{}',error_json=NULL,\\\\n lease_owner=NULL,lease_expires_at=NULL,lease_instance_id=NULL,lease_attempt_id=NULL,updated_at=datetime('now')\\\\n WHERE id=? AND state='LEASED' AND lease_owner=? AND lease_instance_id=? AND lease_attempt_id=?\\\\n AND transport_lease_generation=? AND lease_expires_at>datetime('now') RETURNING id,state\\\\\\\"\\\\\\\"\\\\\\\",\\\\n (id,WORKER,INSTANCE,attempt,generation)).fetchone(); db.commit()\\\\n return dict(r) if r else None\\\\n\\\\ndef recover(db):\\\\n ids=[r[\\\\\\\"id\\\\\\\"] for r in db.execute(\\\\\\\"\\\\\\\"\\\\\\\"SELECT id FROM jobs WHERE state='LEASED'\\\\n AND lease_expires_at IS NOT NULL AND lease_expires_at<=datetime('now')\\\\\\\"\\\\\\\"\\\\\\\")]\\\\n for id in ids:\\\\n db.execute(\\\\\\\"\\\\\\\"\\\\\\\"UPDATE jobs SET state='FAILED',result_json=NULL,\\\\n error_json=json_object('classification','TRANSPORT_LEASE_EXPIRED_OUTCOME_UNKNOWN_REQUIRES_CANONICAL_RECONCILIATION'),\\\\n lease_owner=NULL,lease_expires_at=NULL,lease_instance_id=NULL,lease_attempt_id=NULL\\\\n WHERE id=?\\\\\\\"\\\\\\\"\\\\\\\",(id,))\\\\n db.commit(); return ids\\\\n\\\\ndef active_mutations(db):\\\\n return [r[\\\\\\\"id\\\\\\\"] for r in db.execute(f\\\\\\\"\\\\\\\"\\\\\\\"SELECT id FROM jobs j WHERE state='LEASED'\\\\n AND lease_expires_at>datetime('now') AND NOT {ro('j')} ORDER BY id\\\\\\\"\\\\\\\"\\\\\\\")]\\\\n\\\\nT=[]\\\\ndef check(name,cond): T.append((name,bool(cond)))\\\\n\\\\n# mutation blocks mutation, not read\\\\ndb=setup(); add(db,\\\\\\\"m0\\\\\\\",\\\\\\\"commit\\\\\\\",\\\\\\\"LEASED\\\\\\\",owner=WORKER,expires=\\\\\\\"2099-01-01 00:00:00\\\\\\\",attempt=\\\\\\\"m0\\\\\\\",generation=1)\\\\nadd(db,\\\\\\\"m1\\\\\\\",\\\\\\\"claim\\\\\\\",priority=200); add(db,\\\\\\\"r1\\\\\\\",\\\\\\\"status\\\\\\\",priority=100)\\\\na=lease(db,\\\\\\\"a\\\\\\\"); b=lease(db,\\\\\\\"b\\\\\\\")\\\\ncheck(\\\\\\\"mutation_allows_read\\\\\\\",a and a[\\\\\\\"id\\\\\\\"]==\\\\\\\"r1\\\\\\\"); check(\\\\\\\"mutation_blocks_second_mutation\\\\\\\",b is None)\\\\n\\\\n# read blocks nothing\\\\ndb=setup(); add(db,\\\\\\\"r0\\\\\\\",\\\\\\\"verify-chain\\\\\\\",\\\\\\\"LEASED\\\\\\\",owner=WORKER,expires=\\\\\\\"2099-01-01 00:00:00\\\\\\\",attempt=\\\\\\\"r0\\\\\\\",generation=1)\\\\nadd(db,\\\\\\\"m1\\\\\\\",\\\\\\\"commit\\\\\\\",priority=200); add(db,\\\\\\\"r1\\\\\\\",\\\\\\\"status\\\\\\\",priority=100)\\\\na=lease(db,\\\\\\\"a\\\\\\\"); b=lease(db,\\\\\\\"b\\\\\\\")\\\\ncheck(\\\\\\\"read_does_not_block_mutation\\\\\\\",a and a[\\\\\\\"id\\\\\\\"]==\\\\\\\"m1\\\\\\\"); check(\\\\\\\"read_concurrency_after_mutation_lease\\\\\\\",b and b[\\\\\\\"id\\\\\\\"]==\\\\\\\"r1\\\\\\\")\\\\n\\\\n# exact attempt finish\\\\ndb=setup(); add(db,\\\\\\\"r\\\\\\\",\\\\\\\"status\\\\\\\"); a=lease(db,\\\\\\\"good\\\\\\\")\\\\ncheck(\\\\\\\"wrong_attempt_finish_rejected\\\\\\\",finish(db,\\\\\\\"r\\\\\\\",\\\\\\\"bad\\\\\\\",a[\\\\\\\"transport_lease_generation\\\\\\\"]) is None)\\\\ncheck(\\\\\\\"exact_attempt_finish_accepted\\\\\\\",finish(db,\\\\\\\"r\\\\\\\",\\\\\\\"good\\\\\\\",a[\\\\\\\"transport_lease_generation\\\\\\\"]) is not None)\\\\n\\\\n# expiry unknown and progress\\\\ndb=setup(); add(db,\\\\\\\"old\\\\\\\",\\\\\\\"commit\\\\\\\",\\\\\\\"LEASED\\\\\\\",owner=WORKER,expires=\\\\\\\"2000-01-01 00:00:00\\\\\\\",attempt=\\\\\\\"o\\\\\\\",generation=1); add(db,\\\\\\\"next\\\\\\\",\\\\\\\"claim\\\\\\\")\\\\nids=recover(db); old=db.execute(\\\\\\\"SELECT * FROM jobs WHERE id='old'\\\\\\\").fetchone(); nxt=lease(db,\\\\\\\"n\\\\\\\")\\\\ncheck(\\\\\\\"expired_mutation_unknown\\\\\\\", \\\\\\\"old\\\\\\\" in ids and old[\\\\\\\"state\\\\\\\"]==\\\\\\\"FAILED\\\\\\\" and \\\\\\\"OUTCOME_UNKNOWN\\\\\\\" in old[\\\\\\\"error_json\\\\\\\"])\\\\ncheck(\\\\\\\"progress_after_expiry\\\\\\\",nxt and nxt[\\\\\\\"id\\\\\\\"]==\\\\\\\"next\\\\\\\")\\\\n\\\\n# terminal no replay\\\\ndb=setup(); add(db,\\\\\\\"r\\\\\\\",\\\\\\\"status\\\\\\\"); a=lease(db,\\\\\\\"a\\\\\\\"); finish(db,\\\\\\\"r\\\\\\\",\\\\\\\"a\\\\\\\",a[\\\\\\\"transport_lease_generation\\\\\\\"])\\\\ncheck(\\\\\\\"terminal_not_replayed\\\\\\\",lease(db,\\\\\\\"b\\\\\\\") is None)\\\\n\\\\n# malformed fail closed for mutation but not reads\\\\ndb=setup(); add(db,\\\\\\\"bad\\\\\\\",\\\\\\\"status\\\\\\\",\\\\\\\"LEASED\\\\\\\",owner=WORKER,expires=\\\\\\\"2099-01-01 00:00:00\\\\\\\",attempt=\\\\\\\"x\\\\\\\",generation=1,payload_json=payload(\\\\\\\"status\\\\\\\",extra=True))\\\\nadd(db,\\\\\\\"m\\\\\\\",\\\\\\\"claim\\\\\\\",priority=200); add(db,\\\\\\\"r\\\\\\\",\\\\\\\"verify-claim-graph\\\\\\\",priority=100)\\\\ncheck(\\\\\\\"malformed_active_is_mutation_class\\\\\\\",active_mutations(db)==[\\\\\\\"bad\\\\\\\"])\\\\na=lease(db,\\\\\\\"r1\\\\\\\"); b=lease(db,\\\\\\\"m1\\\\\\\")\\\\ncheck(\\\\\\\"malformed_active_allows_closed_read\\\\\\\",a and a[\\\\\\\"id\\\\\\\"]==\\\\\\\"r\\\\\\\")\\\\ncheck(\\\\\\\"malformed_active_blocks_mutation\\\\\\\",b is None)\\\\n\\\\n# lanes\\\\ndb=setup(); add(db,\\\\\\\"m1\\\\\\\",\\\\\\\"commit\\\\\\\",priority=200); add(db,\\\\\\\"m2\\\\\\\",\\\\\\\"claim\\\\\\\",priority=100)\\\\na=lease(db,\\\\\\\"1\\\\\\\"); b=lease(db,\\\\\\\"2\\\\\\\")\\\\ncheck(\\\\\\\"single_flight_mutation\\\\\\\",a and a[\\\\\\\"id\\\\\\\"]==\\\\\\\"m1\\\\\\\" and b is None)\\\\ndb=setup(); add(db,\\\\\\\"r1\\\\\\\",\\\\\\\"status\\\\\\\",priority=200); add(db,\\\\\\\"r2\\\\\\\",\\\\\\\"verify-chain\\\\\\\",priority=100)\\\\na=lease(db,\\\\\\\"1\\\\\\\"); b=lease(db,\\\\\\\"2\\\\\\\")\\\\ncheck(\\\\\\\"concurrent_reads\\\\\\\",a and b and {a[\\\\\\\"id\\\\\\\"],b[\\\\\\\"id\\\\\\\"]}=={\\\\\\\"r1\\\\\\\",\\\\\\\"r2\\\\\\\"})\\\\n\\\\nresult={\\\\\\\"schema\\\\\\\":\\\\\\\"ABANDONED_TRANSPORT_LANE_ISOLATION_HARNESS_V2\\\\\\\",\\\\\\\"pass\\\\\\\":all(v for _,v in T),\\\\n \\\\\\\"test_count\\\\\\\":len(T),\\\\\\\"failed\\\\\\\":[n for n,v in T if not v],\\\\n \\\\\\\"tests\\\\\\\":[{\\\\\\\"name\\\\\\\":n,\\\\\\\"pass\\\\\\\":v} for n,v in T]}\\\\nprint(json.dumps(result,separators=(\\\\\\\",\\\\\\\",\\\\\\\":\\\\\\\")))\\\\n\\\"\\n },\\n \\\"execution_receipt\\\": {\\n \\\"bytes\\\": 1817,\\n \\\"sha256\\\": \\\"4f44a4a46997c065c05626d3a6c539203b32ca84d618689f42c80bbd40ee4ee4\\\",\\n \\\"content\\\": {\\n \\\"schema\\\": \\\"ABANDONED_TRANSPORT_LANE_ISOLATION_HARNESS_EXECUTION_RECEIPT_V2\\\",\\n \\\"classification\\\": \\\"LOCAL_ISOLATED_EXECUTION_EVIDENCE_CANDIDATE_NONAUTHORITY\\\",\\n \\\"harness_bytes\\\": 6734,\\n \\\"harness_sha256\\\": \\\"b7ea9fe9410234d5f7ae19549188410e057f6de768d41084946d8f941cccedc0\\\",\\n \\\"interpreter\\\": \\\"CPython sqlite3 in-memory\\\",\\n \\\"exit_code\\\": 0,\\n \\\"stdout_json\\\": {\\n \\\"schema\\\": \\\"ABANDONED_TRANSPORT_LANE_ISOLATION_HARNESS_V2\\\",\\n \\\"pass\\\": true,\\n \\\"test_count\\\": 14,\\n \\\"failed\\\": [],\\n \\\"tests\\\": [\\n {\\n \\\"name\\\": \\\"mutation_allows_read\\\",\\n \\\"pass\\\": true\\n },\\n {\\n \\\"name\\\": \\\"mutation_blocks_second_mutation\\\",\\n \\\"pass\\\": true\\n },\\n {\\n \\\"name\\\": \\\"read_does_not_block_mutation\\\",\\n \\\"pass\\\": true\\n },\\n {\\n \\\"name\\\": \\\"read_concurrency_after_mutation_lease\\\",\\n \\\"pass\\\": true\\n },\\n {\\n \\\"name\\\": \\\"wrong_attempt_finish_rejected\\\",\\n \\\"pass\\\": true\\n },\\n {\\n \\\"name\\\": \\\"exact_attempt_finish_accepted\\\",\\n \\\"pass\\\": true\\n },\\n {\\n \\\"name\\\": \\\"expired_mutation_unknown\\\",\\n \\\"pass\\\": true\\n },\\n {\\n \\\"name\\\": \\\"progress_after_expiry\\\",\\n \\\"pass\\\": true\\n },\\n {\\n \\\"name\\\": \\\"terminal_not_replayed\\\",\\n \\\"pass\\\": true\\n },\\n {\\n \\\"name\\\": \\\"malformed_active_is_mutation_class\\\",\\n \\\"pass\\\": true\\n },\\n {\\n \\\"name\\\": \\\"malformed_active_allows_closed_read\\\",\\n \\\"pass\\\": true\\n },\\n {\\n \\\"name\\\": \\\"malformed_active_blocks_mutation\\\",\\n \\\"pass\\\": true\\n },\\n {\\n \\\"name\\\": \\\"single_flight_mutation\\\",\\n \\\"pass\\\": true\\n },\\n {\\n \\\"name\\\": \\\"concurrent_reads\\\",\\n \\\"pass\\\": true\\n }\\n ]\\n },\\n \\\"production_mutation\\\": false,\\n \\\"direct_sprites_calls\\\": 0,\\n \\\"human_authority_approval\\\": false,\\n \\\"p_real_increment\\\": 0\\n }\\n },\\n \\\"explicit_invariants\\\": [\\n \\\"at most one active mutation transport lease\\\",\\n \\\"exact closed-schema status/verify-chain/verify-claim-graph may coexist with active mutation and with each other\\\",\\n \\\"malformed or unknown active transport payload is mutation-class fail-closed\\\",\\n \\\"preserve exact-attempt result fencing\\\",\\n \\\"preserve expired mutation UNKNOWN_OUTCOME semantics\\\",\\n \\\"terminal jobs are never replayed\\\",\\n \\\"PREPARED_READ_ONLY admits only exact read-only commands\\\",\\n \\\"reconcileExactLeaseAttemptR2 cannot convert ambiguous acquisition into unsafe progress\\\",\\n \\\"transformed lease SQL must remain placeholder-compatible with leaseOneSql\\\",\\n \\\"no duplicate canonical mutation execution\\\"\\n ],\\n \\\"required_attacks\\\": [\\n \\\"mutation single-flight\\\",\\n \\\"read/mutation lane arbitration\\\",\\n \\\"malformed payload classification\\\",\\n \\\"exact-attempt finish fencing\\\",\\n \\\"expired mutation UNKNOWN_OUTCOME behavior\\\",\\n \\\"replay\\\",\\n \\\"PREPARED_READ_ONLY semantics\\\",\\n \\\"reconcileExactLeaseAttemptR2 semantics\\\",\\n \\\"queue ordering\\\",\\n \\\"transformed lease SQL placeholder compatibility\\\",\\n \\\"harness/receipt identity mismatch\\\"\\n ],\\n \\\"authority_effects\\\": {\\n \\\"canonical_mutation\\\": false,\\n \\\"production_mutation\\\": false,\\n \\\"p_real_increment\\\": 0,\\n \\\"independent_review_claimed\\\": false,\\n \\\"human_authority_approval\\\": false,\\n \\\"direct_sprites_calls\\\": 0,\\n \\\"additional_out_of_pocket_spend_usd\\\": 0\\n }\\n}\\n\", H=\"18318806b5954238fc624e3eea328d6cefb377183909a3c5be72bb97a9146aee\";\nasync 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(\"\")}\nif(await sha(P)!==H)throw new Error(\"PACKET_HASH_MISMATCH\");\nconst model=\"cohere/north-mini-code:free\",gateway=\"https://api.kilo.ai/api/gateway/chat/completions\";\nconst prompt=[\n\"Second independent review of exact packet SHA \"+H+\".\",\n\"Be source-literal. An attack is COUNTEREXAMPLE only if you provide a reachable ordered state sequence and quote/identify the exact candidate construct that permits it.\",\n\"Imported symbols count as defined. Search the FULL candidate source before claiming a symbol is missing.\",\n\"Review each required_attacks item separately with status PASS, COUNTEREXAMPLE, or NOT_PROVEN and one concise source reason.\",\n\"The harness identity mismatch is objective if stored bytes/hash differ from the receipt. Separate that evidence-integrity verdict from candidate semantics.\",\n\"Do not infer candidate semantic failure merely because execution evidence is invalid.\",\n\"Return ONLY JSON with keys overall_verdict,candidate_semantics_verdict,evidence_integrity_verdict,attacks,reachable_counterexamples,false_positive_checks,minimum_fix.\",\n\"PACKET:\\n\"+P\n].join(\"\\n\");\nconst started=new Date().toISOString(),t=Date.now();\nconst resp=await fetch(gateway,{method:\"POST\",headers:{\"content-type\":\"application/json\"},body:JSON.stringify({model,messages:[{role:\"user\",content:prompt}],temperature:0,max_tokens:3000,stream:false,response_format:{type:\"json_object\"}})});\nconst raw=await resp.text(),finished=new Date().toISOString();\nlet parsed:any=null,rawVerdict=\"\";\nif(resp.ok){const j=JSON.parse(raw),m=j?.choices?.[0]?.message??{};for(const c of [m.content,m.reasoning_content,m.reasoning,j?.choices?.[0]?.text]){if(typeof c!==\"string\"||!c.trim())continue;const a=c.indexOf(\"{\"),b=c.lastIndexOf(\"}\");if(a>=0&&b>=a){try{parsed=JSON.parse(c.slice(a,b+1));rawVerdict=c;break}catch{}}}\n console.log(JSON.stringify({schema:\"ABANDONED_TRANSPORT_LANE_EXTERNAL_REVIEW_V2\",packet_sha256:H,packet_hash_verified:true,model,returned_model:j?.model??null,provider_response_id:j?.id??null,started,finished,ms:Date.now()-t,http_status:resp.status,usage:j?.usage??null,reported_cost:j?.usage?.cost??null,review:parsed,raw_verdict:rawVerdict,raw_verdict_sha256:rawVerdict?await sha(rawVerdict):null},null,2));\n}else console.log(JSON.stringify({schema:\"ABANDONED_TRANSPORT_LANE_EXTERNAL_REVIEW_V2\",packet_sha256:H,model,started,finished,ms:Date.now()-t,http_status:resp.status,error:raw.slice(0,1000)},null,2));",[],[187],"1b9b414a-c891-4623-9474-078c54badc3b","review.ts","21b18be0-ac8a-11f1-9d99-1607ee4eb77e",["D",1788984469578],"const PACKET=\"{\\n \\\"schema\\\": \\\"ABANDONED_TRANSPORT_LANE_ISOLATION_FROZEN_REVIEW_PACKET_V1\\\",\\n \\\"classification\\\": \\\"CANDIDATE_ONLY_SECOND_PARTY_REVIEW_PACKET\\\",\\n \\\"task\\\": \\\"BRAIN-VAL-NATIVE-ABANDONED-TRANSPORT-LANE-ISOLATION-SECOND-PARTY-REVIEW-V1-20260908\\\",\\n \\\"producer\\\": \\\"chat-unproven-gpt56sol-20260909-2158-bbn-r1-k4x9p2\\\",\\n \\\"current_production_executor\\\": {\\n \\\"bytes\\\": 43706,\\n \\\"sha256\\\": \\\"dc142fb629c3197d79f0a9f772b639169ec86598d7b65a7f08a1c8b7c77adf0f\\\"\\n },\\n \\\"candidate_base\\\": {\\n \\\"path\\\": \\\"val_native_executor_prod.ts\\\",\\n \\\"version\\\": 2262,\\n \\\"bytes\\\": 25168,\\n \\\"sha256\\\": \\\"5547fe98a5ae7bc59c212f5867bb1d386542b6114e3001d88c64e0aeb15d5d05\\\"\\n },\\n \\\"candidate\\\": {\\n \\\"bytes\\\": 26742,\\n \\\"sha256\\\": \\\"1c6b354bae0c5aecf55555343b3dc76638d1dcb8333d855ce987e6735e904c49\\\",\\n \\\"source\\\": \\\"import { sqlite } from \\\\\\\"https://esm.town/v/std/sqlite/main.ts\\\\\\\";\\\\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\\\\\\\";\\\\nconst WORKER=\\\\\\\"project-brain-val-native-v1\\\\\\\";\\\\nconst INSTANCE=\\\\\\\"val-native-epoch2\\\\\\\";\\\\nconst LEASE_SECONDS=180;\\\\nconst TRANSPORT_PAYLOAD_TIMEOUT_MAX=120;\\\\nfunction readOnlyTransportSql(alias:string){\\\\n return `(${alias}.op='brain' AND json_valid(${alias}.payload_json)=1\\\\n AND json_type(${alias}.payload_json,'$.args')='array'\\\\n AND json_array_length(json_extract(${alias}.payload_json,'$.args'))=1\\\\n AND json_extract(${alias}.payload_json,'$.args[0]') IN ('status','verify-chain','verify-claim-graph')\\\\n AND json_type(${alias}.payload_json,'$.timeout')='integer'\\\\n AND json_extract(${alias}.payload_json,'$.timeout') BETWEEN 1 AND ${TRANSPORT_PAYLOAD_TIMEOUT_MAX}\\\\n AND (SELECT COUNT(*) FROM json_each(${alias}.payload_json))=2)`;\\\\n}\\\\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}\\\\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,lease_instance_id=NULL,lease_attempt_id=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 activeMutationLeases(){\\\\n const ro=readOnlyTransportSql(\\\\\\\"j\\\\\\\");\\\\n const r:any=await sqlite.execute(`SELECT j.id,j.lease_owner,j.lease_instance_id,j.lease_attempt_id,j.lease_expires_at\\\\n FROM ${JOB_TABLE} j\\\\n WHERE j.state='LEASED' AND j.lease_expires_at>datetime('now')\\\\n AND NOT ${ro}\\\\n ORDER BY j.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}\\\\nfunction laneAwareLeaseSql(sql:string){\\\\n const needle=`AND NOT EXISTS(\\\\n SELECT 1 FROM ${JOB_TABLE} x\\\\n WHERE x.state='LEASED' AND x.lease_owner=? AND x.lease_expires_at > datetime('now')\\\\n )`;\\\\n if(sql.split(needle).length!==2)throw new Error(\\\\\\\"LANE_AWARE_LEASE_GATE_SHAPE_DRIFT\\\\\\\");\\\\n const readCandidate=readOnlyTransportSql(\\\\\\\"j\\\\\\\");\\\\n const readActive=readOnlyTransportSql(\\\\\\\"x\\\\\\\");\\\\n return sql.replace(needle,`AND (\\\\n ${readCandidate}\\\\n OR NOT EXISTS(\\\\n SELECT 1 FROM ${JOB_TABLE} x\\\\n WHERE x.state='LEASED' AND x.lease_owner=? AND x.lease_expires_at > datetime('now')\\\\n AND NOT ${readActive}\\\\n )\\\\n )`);\\\\n}\\\\nasync function leaseOne(){\\\\n const gate=await admit();if(!gate.ok)return {kind:\\\\\\\"fenced\\\\\\\",gate} as const;\\\\n await recoverExpiredTransport();\\\\n const activeMutations=await activeMutationLeases();\\\\n if(activeMutations.length>1)return {kind:\\\\\\\"conflict\\\\\\\",active:activeMutations} 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:laneAwareLeaseSql(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;\\\\n if(!j){\\\\n if(activeMutations.length===1)return {kind:\\\\\\\"busy_mutation\\\\\\\",active:activeMutations[0]} as const;\\\\n return {kind:\\\\\\\"empty\\\\\\\"} as const;\\\\n }\\\\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} as const;\\\\n}\\\\nasync function finish(job:any,epoch:number,ok:boolean,value:any){\\\\n const gate=await admit();\\\\n if(!gate.ok||Number(gate.epoch)!==epoch){\\\\n return {ok:false,reason:\\\\\\\"CONTROL_PLANE_RESULT_FENCED\\\\\\\",authority:gate.authority??null};\\\\n }\\\\n const result=ok?legacyEnvelope(value):null;\\\\n const error=ok?null:JSON.stringify(value);\\\\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,lease_instance_id=NULL,lease_attempt_id=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`,\\\\n args:[ok?\\\\\\\"COMPLETE\\\\\\\":\\\\\\\"FAILED\\\\\\\",result,error,job.id,WORKER,INSTANCE,job.lease_attempt_id,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:ok?\\\\\\\"COMPLETE\\\\\\\":\\\\\\\"FAILED\\\\\\\"};\\\\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;idatetime('now')\\\\n AND NOT {ro('x')}\\\\n ))\\\\n ORDER BY priority DESC, created_at, j.rowid LIMIT 1)\\\\n RETURNING id,transport_lease_generation,lease_attempt_id\\\\\\\"\\\\\\\"\\\\\\\"\\\\n r=db.execute(sql,(WORKER,INSTANCE,attempt,WORKER)).fetchone(); db.commit()\\\\n return dict(r) if r else None\\\\n\\\\ndef finish(db,id,attempt,generation):\\\\n r=db.execute(\\\\\\\"\\\\\\\"\\\\\\\"UPDATE jobs SET state='COMPLETE',result_json='{}',error_json=NULL,\\\\n lease_owner=NULL,lease_expires_at=NULL,lease_instance_id=NULL,lease_attempt_id=NULL,updated_at=datetime('now')\\\\n WHERE id=? AND state='LEASED' AND lease_owner=? AND lease_instance_id=? AND lease_attempt_id=?\\\\n AND transport_lease_generation=? AND lease_expires_at>datetime('now') RETURNING id,state\\\\\\\"\\\\\\\"\\\\\\\",\\\\n (id,WORKER,INSTANCE,attempt,generation)).fetchone(); db.commit()\\\\n return dict(r) if r else None\\\\n\\\\ndef recover(db):\\\\n ids=[r[\\\\\\\"id\\\\\\\"] for r in db.execute(\\\\\\\"\\\\\\\"\\\\\\\"SELECT id FROM jobs WHERE state='LEASED'\\\\n AND lease_expires_at IS NOT NULL AND lease_expires_at<=datetime('now')\\\\\\\"\\\\\\\"\\\\\\\")]\\\\n for id in ids:\\\\n db.execute(\\\\\\\"\\\\\\\"\\\\\\\"UPDATE jobs SET state='FAILED',result_json=NULL,\\\\n error_json=json_object('classification','TRANSPORT_LEASE_EXPIRED_OUTCOME_UNKNOWN_REQUIRES_CANONICAL_RECONCILIATION'),\\\\n lease_owner=NULL,lease_expires_at=NULL,lease_instance_id=NULL,lease_attempt_id=NULL\\\\n WHERE id=?\\\\\\\"\\\\\\\"\\\\\\\",(id,))\\\\n db.commit(); return ids\\\\n\\\\ndef active_mutations(db):\\\\n return [r[\\\\\\\"id\\\\\\\"] for r in db.execute(f\\\\\\\"\\\\\\\"\\\\\\\"SELECT id FROM jobs j WHERE state='LEASED'\\\\n AND lease_expires_at>datetime('now') AND NOT {ro('j')} ORDER BY id\\\\\\\"\\\\\\\"\\\\\\\")]\\\\n\\\\nT=[]\\\\ndef check(name,cond): T.append((name,bool(cond)))\\\\n\\\\n# mutation blocks mutation, not read\\\\ndb=setup(); add(db,\\\\\\\"m0\\\\\\\",\\\\\\\"commit\\\\\\\",\\\\\\\"LEASED\\\\\\\",owner=WORKER,expires=\\\\\\\"2099-01-01 00:00:00\\\\\\\",attempt=\\\\\\\"m0\\\\\\\",generation=1)\\\\nadd(db,\\\\\\\"m1\\\\\\\",\\\\\\\"claim\\\\\\\",priority=200); add(db,\\\\\\\"r1\\\\\\\",\\\\\\\"status\\\\\\\",priority=100)\\\\na=lease(db,\\\\\\\"a\\\\\\\"); b=lease(db,\\\\\\\"b\\\\\\\")\\\\ncheck(\\\\\\\"mutation_allows_read\\\\\\\",a and a[\\\\\\\"id\\\\\\\"]==\\\\\\\"r1\\\\\\\"); check(\\\\\\\"mutation_blocks_second_mutation\\\\\\\",b is None)\\\\n\\\\n# read blocks nothing\\\\ndb=setup(); add(db,\\\\\\\"r0\\\\\\\",\\\\\\\"verify-chain\\\\\\\",\\\\\\\"LEASED\\\\\\\",owner=WORKER,expires=\\\\\\\"2099-01-01 00:00:00\\\\\\\",attempt=\\\\\\\"r0\\\\\\\",generation=1)\\\\nadd(db,\\\\\\\"m1\\\\\\\",\\\\\\\"commit\\\\\\\",priority=200); add(db,\\\\\\\"r1\\\\\\\",\\\\\\\"status\\\\\\\",priority=100)\\\\na=lease(db,\\\\\\\"a\\\\\\\"); b=lease(db,\\\\\\\"b\\\\\\\")\\\\ncheck(\\\\\\\"read_does_not_block_mutation\\\\\\\",a and a[\\\\\\\"id\\\\\\\"]==\\\\\\\"m1\\\\\\\"); check(\\\\\\\"read_concurrency_after_mutation_lease\\\\\\\",b and b[\\\\\\\"id\\\\\\\"]==\\\\\\\"r1\\\\\\\")\\\\n\\\\n# exact attempt finish\\\\ndb=setup(); add(db,\\\\\\\"r\\\\\\\",\\\\\\\"status\\\\\\\"); a=lease(db,\\\\\\\"good\\\\\\\")\\\\ncheck(\\\\\\\"wrong_attempt_finish_rejected\\\\\\\",finish(db,\\\\\\\"r\\\\\\\",\\\\\\\"bad\\\\\\\",a[\\\\\\\"transport_lease_generation\\\\\\\"]) is None)\\\\ncheck(\\\\\\\"exact_attempt_finish_accepted\\\\\\\",finish(db,\\\\\\\"r\\\\\\\",\\\\\\\"good\\\\\\\",a[\\\\\\\"transport_lease_generation\\\\\\\"]) is not None)\\\\n\\\\n# expiry unknown and progress\\\\ndb=setup(); add(db,\\\\\\\"old\\\\\\\",\\\\\\\"commit\\\\\\\",\\\\\\\"LEASED\\\\\\\",owner=WORKER,expires=\\\\\\\"2000-01-01 00:00:00\\\\\\\",attempt=\\\\\\\"o\\\\\\\",generation=1); add(db,\\\\\\\"next\\\\\\\",\\\\\\\"claim\\\\\\\")\\\\nids=recover(db); old=db.execute(\\\\\\\"SELECT * FROM jobs WHERE id='old'\\\\\\\").fetchone(); nxt=lease(db,\\\\\\\"n\\\\\\\")\\\\ncheck(\\\\\\\"expired_mutation_unknown\\\\\\\", \\\\\\\"old\\\\\\\" in ids and old[\\\\\\\"state\\\\\\\"]==\\\\\\\"FAILED\\\\\\\" and \\\\\\\"OUTCOME_UNKNOWN\\\\\\\" in old[\\\\\\\"error_json\\\\\\\"])\\\\ncheck(\\\\\\\"progress_after_expiry\\\\\\\",nxt and nxt[\\\\\\\"id\\\\\\\"]==\\\\\\\"next\\\\\\\")\\\\n\\\\n# terminal no replay\\\\ndb=setup(); add(db,\\\\\\\"r\\\\\\\",\\\\\\\"status\\\\\\\"); a=lease(db,\\\\\\\"a\\\\\\\"); finish(db,\\\\\\\"r\\\\\\\",\\\\\\\"a\\\\\\\",a[\\\\\\\"transport_lease_generation\\\\\\\"])\\\\ncheck(\\\\\\\"terminal_not_replayed\\\\\\\",lease(db,\\\\\\\"b\\\\\\\") is None)\\\\n\\\\n# malformed fail closed for mutation but not reads\\\\ndb=setup(); add(db,\\\\\\\"bad\\\\\\\",\\\\\\\"status\\\\\\\",\\\\\\\"LEASED\\\\\\\",owner=WORKER,expires=\\\\\\\"2099-01-01 00:00:00\\\\\\\",attempt=\\\\\\\"x\\\\\\\",generation=1,payload_json=payload(\\\\\\\"status\\\\\\\",extra=True))\\\\nadd(db,\\\\\\\"m\\\\\\\",\\\\\\\"claim\\\\\\\",priority=200); add(db,\\\\\\\"r\\\\\\\",\\\\\\\"verify-claim-graph\\\\\\\",priority=100)\\\\ncheck(\\\\\\\"malformed_active_is_mutation_class\\\\\\\",active_mutations(db)==[\\\\\\\"bad\\\\\\\"])\\\\na=lease(db,\\\\\\\"r1\\\\\\\"); b=lease(db,\\\\\\\"m1\\\\\\\")\\\\ncheck(\\\\\\\"malformed_active_allows_closed_read\\\\\\\",a and a[\\\\\\\"id\\\\\\\"]==\\\\\\\"r\\\\\\\")\\\\ncheck(\\\\\\\"malformed_active_blocks_mutation\\\\\\\",b is None)\\\\n\\\\n# lanes\\\\ndb=setup(); add(db,\\\\\\\"m1\\\\\\\",\\\\\\\"commit\\\\\\\",priority=200); add(db,\\\\\\\"m2\\\\\\\",\\\\\\\"claim\\\\\\\",priority=100)\\\\na=lease(db,\\\\\\\"1\\\\\\\"); b=lease(db,\\\\\\\"2\\\\\\\")\\\\ncheck(\\\\\\\"single_flight_mutation\\\\\\\",a and a[\\\\\\\"id\\\\\\\"]==\\\\\\\"m1\\\\\\\" and b is None)\\\\ndb=setup(); add(db,\\\\\\\"r1\\\\\\\",\\\\\\\"status\\\\\\\",priority=200); add(db,\\\\\\\"r2\\\\\\\",\\\\\\\"verify-chain\\\\\\\",priority=100)\\\\na=lease(db,\\\\\\\"1\\\\\\\"); b=lease(db,\\\\\\\"2\\\\\\\")\\\\ncheck(\\\\\\\"concurrent_reads\\\\\\\",a and b and {a[\\\\\\\"id\\\\\\\"],b[\\\\\\\"id\\\\\\\"]}=={\\\\\\\"r1\\\\\\\",\\\\\\\"r2\\\\\\\"})\\\\n\\\\nresult={\\\\\\\"schema\\\\\\\":\\\\\\\"ABANDONED_TRANSPORT_LANE_ISOLATION_HARNESS_V2\\\\\\\",\\\\\\\"pass\\\\\\\":all(v for _,v in T),\\\\n \\\\\\\"test_count\\\\\\\":len(T),\\\\\\\"failed\\\\\\\":[n for n,v in T if not v],\\\\n \\\\\\\"tests\\\\\\\":[{\\\\\\\"name\\\\\\\":n,\\\\\\\"pass\\\\\\\":v} for n,v in T]}\\\\nprint(json.dumps(result,separators=(\\\\\\\",\\\\\\\",\\\\\\\":\\\\\\\")))\\\\n\\\"\\n },\\n \\\"execution_receipt\\\": {\\n \\\"bytes\\\": 1817,\\n \\\"sha256\\\": \\\"4f44a4a46997c065c05626d3a6c539203b32ca84d618689f42c80bbd40ee4ee4\\\",\\n \\\"content\\\": {\\n \\\"schema\\\": \\\"ABANDONED_TRANSPORT_LANE_ISOLATION_HARNESS_EXECUTION_RECEIPT_V2\\\",\\n \\\"classification\\\": \\\"LOCAL_ISOLATED_EXECUTION_EVIDENCE_CANDIDATE_NONAUTHORITY\\\",\\n \\\"harness_bytes\\\": 6734,\\n \\\"harness_sha256\\\": \\\"b7ea9fe9410234d5f7ae19549188410e057f6de768d41084946d8f941cccedc0\\\",\\n \\\"interpreter\\\": \\\"CPython sqlite3 in-memory\\\",\\n \\\"exit_code\\\": 0,\\n \\\"stdout_json\\\": {\\n \\\"schema\\\": \\\"ABANDONED_TRANSPORT_LANE_ISOLATION_HARNESS_V2\\\",\\n \\\"pass\\\": true,\\n \\\"test_count\\\": 14,\\n \\\"failed\\\": [],\\n \\\"tests\\\": [\\n {\\n \\\"name\\\": \\\"mutation_allows_read\\\",\\n \\\"pass\\\": true\\n },\\n {\\n \\\"name\\\": \\\"mutation_blocks_second_mutation\\\",\\n \\\"pass\\\": true\\n },\\n {\\n \\\"name\\\": \\\"read_does_not_block_mutation\\\",\\n \\\"pass\\\": true\\n },\\n {\\n \\\"name\\\": \\\"read_concurrency_after_mutation_lease\\\",\\n \\\"pass\\\": true\\n },\\n {\\n \\\"name\\\": \\\"wrong_attempt_finish_rejected\\\",\\n \\\"pass\\\": true\\n },\\n {\\n \\\"name\\\": \\\"exact_attempt_finish_accepted\\\",\\n \\\"pass\\\": true\\n },\\n {\\n \\\"name\\\": \\\"expired_mutation_unknown\\\",\\n \\\"pass\\\": true\\n },\\n {\\n \\\"name\\\": \\\"progress_after_expiry\\\",\\n \\\"pass\\\": true\\n },\\n {\\n \\\"name\\\": \\\"terminal_not_replayed\\\",\\n \\\"pass\\\": true\\n },\\n {\\n \\\"name\\\": \\\"malformed_active_is_mutation_class\\\",\\n \\\"pass\\\": true\\n },\\n {\\n \\\"name\\\": \\\"malformed_active_allows_closed_read\\\",\\n \\\"pass\\\": true\\n },\\n {\\n \\\"name\\\": \\\"malformed_active_blocks_mutation\\\",\\n \\\"pass\\\": true\\n },\\n {\\n \\\"name\\\": \\\"single_flight_mutation\\\",\\n \\\"pass\\\": true\\n },\\n {\\n \\\"name\\\": \\\"concurrent_reads\\\",\\n \\\"pass\\\": true\\n }\\n ]\\n },\\n \\\"production_mutation\\\": false,\\n \\\"direct_sprites_calls\\\": 0,\\n \\\"human_authority_approval\\\": false,\\n \\\"p_real_increment\\\": 0\\n }\\n },\\n \\\"explicit_invariants\\\": [\\n \\\"at most one active mutation transport lease\\\",\\n \\\"exact closed-schema status/verify-chain/verify-claim-graph may coexist with active mutation and with each other\\\",\\n \\\"malformed or unknown active transport payload is mutation-class fail-closed\\\",\\n \\\"preserve exact-attempt result fencing\\\",\\n \\\"preserve expired mutation UNKNOWN_OUTCOME semantics\\\",\\n \\\"terminal jobs are never replayed\\\",\\n \\\"PREPARED_READ_ONLY admits only exact read-only commands\\\",\\n \\\"reconcileExactLeaseAttemptR2 cannot convert ambiguous acquisition into unsafe progress\\\",\\n \\\"transformed lease SQL must remain placeholder-compatible with leaseOneSql\\\",\\n \\\"no duplicate canonical mutation execution\\\"\\n ],\\n \\\"required_attacks\\\": [\\n \\\"mutation single-flight\\\",\\n \\\"read/mutation lane arbitration\\\",\\n \\\"malformed payload classification\\\",\\n \\\"exact-attempt finish fencing\\\",\\n \\\"expired mutation UNKNOWN_OUTCOME behavior\\\",\\n \\\"replay\\\",\\n \\\"PREPARED_READ_ONLY semantics\\\",\\n \\\"reconcileExactLeaseAttemptR2 semantics\\\",\\n \\\"queue ordering\\\",\\n \\\"transformed lease SQL placeholder compatibility\\\",\\n \\\"harness/receipt identity mismatch\\\"\\n ],\\n \\\"authority_effects\\\": {\\n \\\"canonical_mutation\\\": false,\\n \\\"production_mutation\\\": false,\\n \\\"p_real_increment\\\": 0,\\n \\\"independent_review_claimed\\\": false,\\n \\\"human_authority_approval\\\": false,\\n \\\"direct_sprites_calls\\\": 0,\\n \\\"additional_out_of_pocket_spend_usd\\\": 0\\n }\\n}\\n\";\nconst EXPECTED_SHA=\"18318806b5954238fc624e3eea328d6cefb377183909a3c5be72bb97a9146aee\";\nasync 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 actual=await sha(PACKET); if(actual!==EXPECTED_SHA) throw new Error(\"PACKET_HASH_MISMATCH:\"+actual);\nconst gateway=\"https://api.kilo.ai/api/gateway/chat/completions\";\nconst models=[\"poolside/laguna-s-2.1:free\",\"cohere/north-mini-code:free\",\"stepfun/step-3.7-flash:free\",\"nex-agi/nex-n2.5-mini:free\"];\nconst rules=[\n\"You are a second-party correctness reviewer. Audit ONLY the exact frozen packet below.\",\n\"Do not assume the builder's claims are true. Treat packet hashes and source as evidence.\",\n\"Attack every required_attacks item, specifically mutation single-flight, read/mutation arbitration, malformed classification, exact-attempt finish fencing, expired mutation UNKNOWN_OUTCOME, replay, PREPARED_READ_ONLY, reconcileExactLeaseAttemptR2, queue ordering, and transformed lease SQL placeholder compatibility.\",\n\"Also adjudicate the explicit mismatch between stored harness bytes/hash and the committed execution receipt. Do not call the old 14/14 execution valid if its source identity does not match.\",\n\"A PASS requires a concrete source-grounded argument that candidate invariants hold AND review evidence is identity-consistent. Otherwise return COUNTEREXAMPLE or EVIDENCE_INTEGRITY_BLOCK.\",\n\"Return ONLY JSON with keys overall_verdict,candidate_semantics_verdict,evidence_integrity_verdict,attacks,reachable_counterexample,source_reason,minimum_fix.\"\n].join(\"\\n\");\nfunction extract(s:string){const a=s.indexOf(\"{\"),b=s.lastIndexOf(\"}\");if(a<0||btypeof x===\"string\"&&x.trim());\n let review:any=null,rawVerdict=\"\";\n for(const c of candidates){review=extract(String(c));if(review){rawVerdict=String(c);break}}\n const out={model,returned_model:j?.model??null,provider_response_id:j?.id??null,started,finished,ms,http_status:resp.status,usage:j?.usage??null,reported_cost:j?.usage?.cost??null,usable:!!review,review,raw_verdict_bytes:new TextEncoder().encode(rawVerdict).length,raw_verdict_sha256:rawVerdict?await sha(rawVerdict):null,raw_verdict:rawVerdict};\n attempts.push(out); if(review){console.log(JSON.stringify({schema:\"ABANDONED_TRANSPORT_LANE_EXTERNAL_REVIEW_V1\",packet_sha256:EXPECTED_SHA,packet_hash_verified:true,reviewer_program:\"isolated_val_external_model_reviewer_v1\",attempts,selected:out,canonical_mutation:false,production_mutation:false,p_real_increment:0,human_authority_approval:false,direct_sprites_calls:0},null,2)); Deno.exit(0)}\n }catch(e){attempts.push({model,started,finished:new Date().toISOString(),ms:Date.now()-t,usable:false,error:String(e)})}\n}\nconsole.log(JSON.stringify({schema:\"ABANDONED_TRANSPORT_LANE_EXTERNAL_REVIEW_V1\",packet_sha256:EXPECTED_SHA,packet_hash_verified:true,attempts,selected:null,canonical_mutation:false,production_mutation:false,p_real_increment:0,human_authority_approval:false,direct_sprites_calls:0},null,2));",[],[195],["D",1788984469538],{"_11":12,"_120":70},{"_11":12,"_115":116,"_69":70,"_30":68,"_117":118,"_119":24},{"_38":106,"_13":16,"_32":35,"_107":72,"_108":-5,"_109":-5,"_110":-5,"_111":-5,"_112":-5,"_113":14,"_114":12},"ctx",{"_53":-5,"_139":238,"_239":240,"_241":242,"_243":24,"_244":24,"_245":24,"_246":169,"_247":-5,"_248":-7,"_249":-7,"_250":26,"_251":24,"_252":24,"_253":-5,"_254":24,"_255":24,"_256":24,"_257":-5},"ENV",{"_209":210,"_211":212,"_213":16,"_214":215,"_216":217,"_218":219,"_220":221,"_222":223,"_224":225,"_226":227,"_228":229,"_230":231,"_232":233,"_234":235,"_236":237},"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"]

History · review3.ts