[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8},"actionData","errors","root",{"_104":105,"_106":107},"routes/embed.x.$handle.$name.$",{"_9":10,"_11":12,"_13":14,"_15":16,"_17":18,"_19":20,"_21":-5},"handle","mosadek","name","brain-lane-review-260909-0024","path","packet.ts","project",{"_22":45,"_11":12,"_33":46,"_47":-5,"_48":42,"_49":50,"_51":50,"_52":53,"_54":-5,"_55":56,"_57":-5,"_58":42,"_59":-5,"_60":-5,"_61":36,"_62":63,"_64":65,"_66":67,"_68":69,"_70":-5,"_71":72,"_73":72,"_74":75,"_76":75,"_77":75,"_78":72,"_79":72,"_80":81,"_82":83,"_84":85,"_86":42},"file",{"_22":23,"_11":14,"_24":25,"_26":-5,"_27":28,"_29":30,"_31":32,"_33":34,"_35":36,"_37":38,"_39":40,"_41":42,"_43":-5,"_13":44},"permalink","https://www.val.town/x/mosadek/brain-lane-review-260909-0024/code/packet.ts","extension","id","afc50c71-0c13-4866-8171-50cbca2ed8b0","fileId","8085c482-abd7-11f1-a396-1607ee4eb77e","parentId","branchId","2f1a1836-bf74-4d54-ac18-24dc4c58d3ee","branchVersion",2,"latest",true,"createdAt",["D",1788907748755],"version",0,"fileType","script","content","export const EXPECTED_PACKET_SHA256=\"377bc1926648caad92432c0a09b7f333eeeaf97b395ac2286c1e6544a258d1c6\";\nexport const PACKET_RAW=\"{\\n \\\"schema\\\": \\\"VAL_NATIVE_ABANDONED_TRANSPORT_LANE_ISOLATION_SECOND_PARTY_REVIEW_PACKET_V1\\\",\\n \\\"classification\\\": \\\"FROZEN_CANDIDATE_NONAUTHORITY_REVIEW_PACKET\\\",\\n \\\"source_shadow_event\\\": {\\n \\\"event_id\\\": 4540,\\n \\\"local_seq\\\": 2549,\\n \\\"event_hash\\\": \\\"bc5e4c144981b2bad430b72097ad88a8716787d37811092e6f27948cfe3b7fd4\\\",\\n \\\"transaction_generation\\\": 4173\\n },\\n \\\"current_production_executor\\\": {\\n \\\"path\\\": \\\"val_native_executor_prod.ts\\\",\\n \\\"bytes\\\": 25168,\\n \\\"sha256\\\": \\\"5547fe98a5ae7bc59c212f5867bb1d386542b6114e3001d88c64e0aeb15d5d05\\\"\\n },\\n \\\"candidate\\\": {\\n \\\"uri\\\": \\\"valblob:mosadek/project-brain-live-v1-durable/evidence/control_plane/abandoned-transport-lease-stall-shadow-v1/chat-unproven-sol56-20260908-2242-brain-r1/val_native_executor_prod_lane_isolation_candidate_v1.ts\\\",\\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') ORDER BY id`);\\\"\\n ],\\n \\\"insert_lines\\\": [\\n \\\"async 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 ]\\n },\\n {\\n \\\"base_start\\\": 174,\\n \\\"candidate_start\\\": 188,\\n \\\"delete_lines\\\": [],\\n \\\"insert_lines\\\": [\\n \\\"function 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 \\\"}\\\"\\n ]\\n },\\n {\\n \\\"base_start\\\": 177,\\n \\\"candidate_start\\\": 208,\\n \\\"delete_lines\\\": [\\n \\\" const active=await activeLeases();\\\",\\n \\\" if(active.length>1)return {kind:\\\\\\\"conflict\\\\\\\",active} as const;\\\",\\n \\\" if(active.length===1)return {kind:\\\\\\\"busy\\\\\\\",active:active[0]} as const;\\\"\\n ],\\n \\\"insert_lines\\\": [\\n \\\" const activeMutations=await activeMutationLeases();\\\",\\n \\\" if(activeMutations.length>1)return {kind:\\\\\\\"conflict\\\\\\\",active:activeMutations} as const;\\\"\\n ]\\n },\\n {\\n \\\"base_start\\\": 227,\\n \\\"candidate_start\\\": 257,\\n \\\"delete_lines\\\": [\\n \\\" : await sqlite.execute({sql:atomicizeLeaseSql(leaseOneSql(JOB_TABLE)),args:[WORKER,INSTANCE,attempt,WORKER]});\\\"\\n ],\\n \\\"insert_lines\\\": [\\n \\\" : await sqlite.execute({sql:laneAwareLeaseSql(atomicizeLeaseSql(leaseOneSql(JOB_TABLE))),args:[WORKER,INSTANCE,attempt,WORKER]});\\\"\\n ]\\n },\\n {\\n \\\"base_start\\\": 238,\\n \\\"candidate_start\\\": 268,\\n \\\"delete_lines\\\": [\\n \\\" const j:any=core.rows?.[0]??null;if(!j)return {kind:\\\\\\\"empty\\\\\\\"} as const;\\\"\\n ],\\n \\\"insert_lines\\\": [\\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 ]\\n }\\n ]\\n }\\n },\\n \\\"route_report\\\": {\\n \\\"uri\\\": \\\"valblob:mosadek/project-brain-live-v1-durable/evidence/control_plane/abandoned-transport-lease-stall-shadow-v1/chat-unproven-sol56-20260908-2242-brain-r1/ROUTE_COMPARISON_AND_ROOT_CAUSE_REPORT_V1.json\\\",\\n \\\"bytes\\\": 2991,\\n \\\"sha256\\\": \\\"909b2fbd0a4b01b0ffc876c2419b27e04dac5311bdae0ea404fa99d30a12be03\\\",\\n \\\"raw_json\\\": \\\"{\\\\n \\\\\\\"schema\\\\\\\": \\\\\\\"ABANDONED_TRANSPORT_LEASE_STALL_ROUTE_COMPARISON_V1\\\\\\\",\\\\n \\\\\\\"classification\\\\\\\": \\\\\\\"CANDIDATE_ONLY_SHADOW_DIAGNOSIS\\\\\\\",\\\\n \\\\\\\"reproduced_root_cause\\\\\\\": {\\\\n \\\\\\\"production_executor_version\\\\\\\": 2262,\\\\n \\\\\\\"production_source_sha256\\\\\\\": \\\\\\\"5547fe98a5ae7bc59c212f5867bb1d386542b6114e3001d88c64e0aeb15d5d05\\\\\\\",\\\\n \\\\\\\"hard_transport_lease_seconds\\\\\\\": 180,\\\\n \\\\\\\"global_active_lease_blocks_other_queue_work\\\\\\\": true,\\\\n \\\\\\\"payload_timeout_validated_1_to_120\\\\\\\": true,\\\\n \\\\\\\"payload_timeout_enforced_as_execution_deadline\\\\\\\": false,\\\\n \\\\\\\"transport_expiry_failures_observed\\\\\\\": 77,\\\\n \\\\\\\"by_command\\\\\\\": {\\\\n \\\\\\\"claim\\\\\\\": 34,\\\\n \\\\\\\"register-agent\\\\\\\": 14,\\\\n \\\\\\\"commit\\\\\\\": 9,\\\\n \\\\\\\"verify-chain\\\\\\\": 6,\\\\n \\\\\\\"status\\\\\\\": 4,\\\\n \\\\\\\"ensure-task\\\\\\\": 3,\\\\n \\\\\\\"verify-claim-graph\\\\\\\": 2,\\\\n \\\\\\\"renew-lease\\\\\\\": 2,\\\\n \\\\\\\"recover-stale\\\\\\\": 2,\\\\n \\\\\\\"migrate-task-invariants\\\\\\\": 1\\\\n }\\\\n },\\\\n \\\\\\\"alternatives\\\\\\\": [\\\\n {\\\\n \\\\\\\"route\\\\\\\": \\\\\\\"shorter_or_command_class_specific_transport_lease\\\\\\\",\\\\n \\\\\\\"verdict\\\\\\\": \\\\\\\"REJECT_AS_PRIMARY\\\\\\\",\\\\n \\\\\\\"reason\\\\\\\": \\\\\\\"payload timeout is not a hard executor deadline; shortening mutation lease can expire a still-live mutation and does not preserve unknown-outcome safety\\\\\\\"\\\\n },\\\\n {\\\\n \\\\\\\"route\\\\\\\": \\\\\\\"bounded_runtime_time_budgeted_lease\\\\\\\",\\\\n \\\\\\\"verdict\\\\\\\": \\\\\\\"DEFER\\\\\\\",\\\\n \\\\\\\"reason\\\\\\\": \\\\\\\"requires a real cancellation/termination primitive around in-process canonical dispatch; timer racing does not stop a live mutation\\\\\\\"\\\\n },\\\\n {\\\\n \\\\\\\"route\\\\\\\": \\\\\\\"attempt_heartbeat_liveness_recovery\\\\\\\",\\\\n \\\\\\\"verdict\\\\\\\": \\\\\\\"DEFER\\\\\\\",\\\\n \\\\\\\"reason\\\\\\\": \\\\\\\"can reduce mutation stall but adds a liveness protocol and new failure modes; not the smallest safe current elimination\\\\\\\"\\\\n },\\\\n {\\\\n \\\\\\\"route\\\\\\\": \\\\\\\"read_only_lane_isolation_from_mutation_stalls\\\\\\\",\\\\n \\\\\\\"verdict\\\\\\\": \\\\\\\"SELECT\\\\\\\",\\\\n \\\\\\\"reason\\\\\\\": \\\\\\\"removes the global nature of the stall while preserving one-at-a-time mutations, exact-attempt fencing, and existing mutation expiry semantics\\\\\\\"\\\\n },\\\\n {\\\\n \\\\\\\"route\\\\\\\": \\\\\\\"shared_coalesced_boot_verification_receipts\\\\\\\",\\\\n \\\\\\\"verdict\\\\\\\": \\\\\\\"COMPLEMENTARY_NOT_ROOT_FIX\\\\\\\",\\\\n \\\\\\\"reason\\\\\\\": \\\\\\\"reduces request load but one abandoned transport lease can still stall unrelated work\\\\\\\"\\\\n },\\\\n {\\\\n \\\\\\\"route\\\\\\\": \\\\\\\"remove_all_transport_serialization\\\\\\\",\\\\n \\\\\\\"verdict\\\\\\\": \\\\\\\"REJECT\\\\\\\",\\\\n \\\\\\\"reason\\\\\\\": \\\\\\\"different mutation attempts could race; attempt-keyed receipts do not make duplicate canonical mutation impossible\\\\\\\"\\\\n }\\\\n ],\\\\n \\\\\\\"selected_candidate\\\\\\\": {\\\\n \\\\\\\"sha256\\\\\\\": \\\\\\\"1c6b354bae0c5aecf55555343b3dc76638d1dcb8333d855ce987e6735e904c49\\\\\\\",\\\\n \\\\\\\"bytes\\\\\\\": 26742,\\\\n \\\\\\\"invariant\\\\\\\": \\\\\\\"at most one active mutation transport lease; exact closed read-only leases may coexist and cannot block mutation or each other\\\\\\\",\\\\n \\\\\\\"expected_effect\\\\\\\": \\\\\\\"abandoned status/verify transport no longer blocks claims/commits; abandoned mutation no longer prevents status/chain/claim-graph visibility; abandoned mutation still blocks a second mutation until canonical expiry/reconciliation\\\\\\\"\\\\n },\\\\n \\\\\\\"production_mutation\\\\\\\": false,\\\\n \\\\\\\"direct_sprites_calls\\\\\\\": 0,\\\\n \\\\\\\"human_authority_approval\\\\\\\": false,\\\\n \\\\\\\"p_real_increment\\\\\\\": 0\\\\n}\\\"\\n },\\n \\\"executed_harness\\\": {\\n \\\"recovered_source_uri\\\": \\\"valblob:mosadek/project-brain-live-v1-durable/evidence/control_plane/abandoned-transport-lease-stall-second-party-v1/chat-unproven-gpt56sol-20260909-0024-k7p2/LANE_ISOLATION_HARNESS_V2_EXECUTED_RECOVERED.py\\\",\\n \\\"bytes\\\": 6734,\\n \\\"sha256\\\": \\\"b7ea9fe9410234d5f7ae19549188410e057f6de768d41084946d8f941cccedc0\\\",\\n \\\"source\\\": \\\"\\\\nimport sqlite3, json\\\\n\\\\nRO = (\\\\\\\"status\\\\\\\",\\\\\\\"verify-chain\\\\\\\",\\\\\\\"verify-claim-graph\\\\\\\")\\\\nWORKER=\\\\\\\"project-brain-val-native-v1\\\\\\\"\\\\nINSTANCE=\\\\\\\"val-native-epoch2\\\\\\\"\\\\n\\\\ndef payload(cmd, timeout=60, extra=False):\\\\n q={\\\\\\\"args\\\\\\\":[cmd],\\\\\\\"timeout\\\\\\\":timeout}\\\\n if extra: q[\\\\\\\"extra\\\\\\\"]=1\\\\n return json.dumps(q,separators=(\\\\\\\",\\\\\\\",\\\\\\\":\\\\\\\"))\\\\n\\\\ndef setup():\\\\n db=sqlite3.connect(\\\\\\\":memory:\\\\\\\")\\\\n db.row_factory=sqlite3.Row\\\\n db.execute(\\\\\\\"\\\\\\\"\\\\\\\"CREATE TABLE jobs(\\\\n id TEXT PRIMARY KEY, op TEXT NOT NULL, payload_json TEXT NOT NULL,\\\\n priority INTEGER NOT NULL DEFAULT 0, state TEXT NOT NULL,\\\\n lease_owner TEXT, lease_expires_at TEXT, transport_lease_generation INTEGER NOT NULL DEFAULT 0,\\\\n lease_instance_id TEXT, lease_attempt_id TEXT, result_json TEXT, error_json TEXT,\\\\n created_at TEXT DEFAULT CURRENT_TIMESTAMP, updated_at TEXT DEFAULT CURRENT_TIMESTAMP)\\\\\\\"\\\\\\\"\\\\\\\")\\\\n return db\\\\n\\\\ndef ro(alias):\\\\n return f\\\\\\\"\\\\\\\"\\\\\\\"({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 120\\\\n AND (SELECT COUNT(*) FROM json_each({alias}.payload_json))=2)\\\\\\\"\\\\\\\"\\\\\\\"\\\\n\\\\ndef add(db,id,cmd,state=\\\\\\\"READY\\\\\\\",priority=10,owner=None,expires=None,attempt=None,generation=0,payload_json=None):\\\\n db.execute(\\\\\\\"\\\\\\\"\\\\\\\"INSERT INTO jobs(id,op,payload_json,priority,state,lease_owner,lease_expires_at,\\\\n transport_lease_generation,lease_instance_id,lease_attempt_id)\\\\n VALUES(?,?,?,?,?,?,?,?,?,?)\\\\\\\"\\\\\\\"\\\\\\\",\\\\n (id,\\\\\\\"brain\\\\\\\",payload_json or payload(cmd),priority,state,owner,expires,generation,INSTANCE if owner else None,attempt))\\\\n db.commit()\\\\n\\\\ndef lease(db, attempt):\\\\n sql=f\\\\\\\"\\\\\\\"\\\\\\\"UPDATE jobs SET state='LEASED', lease_owner=?, lease_expires_at=datetime('now','+180 seconds'),\\\\n transport_lease_generation=transport_lease_generation+1, lease_instance_id=?, lease_attempt_id=?, updated_at=datetime('now')\\\\n WHERE id=(SELECT j.id FROM jobs j WHERE j.state='READY' AND (\\\\n {ro('j')} OR NOT EXISTS(\\\\n SELECT 1 FROM jobs x WHERE x.state='LEASED' AND x.lease_owner=? AND x.lease_expires_at>datetime('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 \\\"recovery_receipt_uri\\\": \\\"valblob:mosadek/project-brain-live-v1-durable/evidence/control_plane/abandoned-transport-lease-stall-second-party-v1/chat-unproven-gpt56sol-20260909-0024-k7p2/HARNESS_RECOVERY_RECEIPT_V1.json\\\"\\n },\\n \\\"harness_execution_receipt\\\": {\\n \\\"uri\\\": \\\"valblob:mosadek/project-brain-live-v1-durable/evidence/control_plane/abandoned-transport-lease-stall-shadow-v1/chat-unproven-sol56-20260908-2242-brain-r1/LANE_ISOLATION_HARNESS_EXECUTION_RECEIPT_V2.json\\\",\\n \\\"bytes\\\": 1817,\\n \\\"sha256\\\": \\\"4f44a4a46997c065c05626d3a6c539203b32ca84d618689f42c80bbd40ee4ee4\\\",\\n \\\"raw_json\\\": \\\"{\\\\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 \\\"invariants\\\": [\\n \\\"at most one active mutation transport lease\\\",\\n \\\"exact closed-schema status/verify-chain/verify-claim-graph are read-only; malformed/unknown payloads are mutation-class fail-closed\\\",\\n \\\"read-only leases may coexist with mutation lease and with one another\\\",\\n \\\"mutation lease acquisition ignores active read-only leases but blocks on active mutation lease\\\",\\n \\\"exact-attempt finish fencing is preserved\\\",\\n \\\"expired mutation remains UNKNOWN_OUTCOME requiring canonical reconciliation\\\",\\n \\\"terminal completed jobs do not replay\\\",\\n \\\"PREPARED_READ_ONLY semantics must remain read-only and non-mutating\\\",\\n \\\"reconcileExactLeaseAttemptR2 must bind exact attempt/generation/result semantics\\\",\\n \\\"queue ordering remains priority DESC then created_at then stable row tie-break\\\",\\n \\\"transformed lease SQL must preserve placeholder/parameter compatibility\\\"\\n ],\\n \\\"minimum_attack_surface\\\": [\\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 ],\\n \\\"review_rules\\\": {\\n \\\"fresh_distinct_execution_required\\\": true,\\n \\\"self_report_is_execution_provenance\\\": false,\\n \\\"zero_additional_spend\\\": true,\\n \\\"no_production_mutation\\\": true,\\n \\\"no_p_real\\\": true,\\n \\\"no_human_authority\\\": true,\\n \\\"no_sprites\\\": true\\n }\\n}\\n\";\n","deleted",false,"label",[14],"5d79550f-5c71-4da8-842b-72216f9c5323",["D",1788907724294],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","Fresh lane-isolation second-party review","imageUrl","userId","6be0fc5c-1fef-4bd6-a1e1-67a3f8c0764e","pinnedFileId","pinPreview","pinMigrated","screenshotVersion","likeCount","orgId","01a0715b-703f-741f-ab35-c85020e4a5e0","tursoName","5d79550f5c714da8842b72216f9c5323","tursoHostname","5d79550f5c714da8842b72216f9c5323-val-town.aws-us-east-2.turso.io","tursoMeasuredAt",["D",1789564254151],"pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_9":10,"_103":99},"org",{"_9":10,"_96":97,"_98":99,"_55":56,"_100":101,"_102":42},"branch",{"_35":30,"_11":87,"_22":28,"_88":45,"_89":-5,"_90":-5,"_91":-5,"_92":-5,"_93":-5,"_94":12,"_95":10},"isOwned","main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","displayName","Mo Sadek","avatar","https://lh3.googleusercontent.com/a/ACg8ocL1eT_LHhKSg5px3nXIO6eez79aZXef466qXKh2gak-0iwrvw=s96-c","tier","free","canRestrictVals","profileImageUrl","ctx",{"_80":-5,"_137":138,"_139":140,"_141":142,"_143":42,"_144":42,"_145":42,"_146":32,"_147":-5,"_148":-7,"_149":-7,"_150":36,"_151":42,"_152":42,"_153":-5,"_154":42,"_155":42,"_156":42,"_157":-5},"ENV",{"_108":109,"_110":111,"_112":87,"_113":114,"_115":116,"_117":118,"_119":120,"_121":122,"_123":124,"_125":126,"_127":128,"_129":130,"_131":132,"_133":134,"_135":136},"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","orgs",[],"preferencesKeybindings","default","preferencesTheme","light","preferencesFixers","preferencesCopilot","preferencesSelectionAi","preferencesCloseBrackets","preferencesChatPanelState","preferencesDprint","preferencesDenofmt","notificationCount","flagDenols","isBusinessOrgMember","businessOrgHandle","isBusinessOrgAdmin","isHigherTownieTier","navCollapsed","currentOrgId"]