[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_714":715,"_716":717},"routes/_app.x.$handle.$name",{"_98":97,"_31":43,"_107":88,"_26":108,"_13":14,"_109":-5,"_11":110,"_111":112,"_113":114,"_115":116,"_117":118,"_20":-5,"_119":-5,"_120":-5,"_121":24,"_122":123,"_124":57,"_125":-5,"_126":-5,"_127":128},"routes/_app.x.$handle.$name.branch.$branch.version.$version.diff",{"_11":12,"_13":14,"_15":16,"_17":-5,"_18":-5},"project",{"_41":42,"_31":43,"_36":44,"_45":-5,"_46":24,"_47":48,"_49":48,"_50":51,"_52":-5,"_18":53,"_54":55,"_56":57,"_58":-5,"_59":-5,"_60":61,"_62":63,"_64":65,"_66":67,"_68":69,"_70":-5,"_71":72,"_73":72,"_74":75,"_76":75,"_77":75,"_78":72,"_79":72,"_80":81,"_82":83,"_84":85,"_86":24},"version",6,"changes",[19],"aiChatInfo","userId",{"_20":21,"_22":-7,"_23":24,"_25":24,"_26":27,"_28":27},"file",{"_29":30,"_31":27,"_32":33,"_34":35,"_36":37,"_38":14,"_39":40,"_23":24},"previous","deleted",false,"deletedHere","path","gc_manifest_sha_v2.ts","latestPath","fileId","a43a181e-aaca-11f1-a2b7-1607ee4eb77e","name","fileType","script","content","import { blob } from \"https://esm.town/v/std/blob/main.ts\";\nconst r=await blob.get(\"gc/file-ceiling-v2/ARCHIVE_RAW_MANIFEST_V2.json\");\nconst b=new Uint8Array(await r.arrayBuffer());\nconst d=new Uint8Array(await crypto.subtle.digest(\"SHA-256\",b));\nconst sha=[...d].map(x=>x.toString(16).padStart(2,\"0\")).join(\"\");\nconsole.log(JSON.stringify({bytes:b.length,sha256:sha},null,2));\n","createdAt",["D",1788792274049],"branchVersion","branchId","dfaa6cf0-d6c1-4d1d-bddb-0d8f8a62293a","id","b26db1a4-9886-4203-a62c-fa490e51e9b5","project-brain-branch-archive-v1",["D",1788778403598],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","Exact frozen Brain branch archive for bounded GC","imageUrl","6be0fc5c-1fef-4bd6-a1e1-67a3f8c0764e","pinnedFileId","01a07b80-917a-70c9-9bdd-76c8831d420a","pinPreview",true,"pinMigrated","screenshotVersion","likeCount",0,"orgId","01a0715b-703f-741f-ab35-c85020e4a5e0","tursoName","b26db1a498864203a62cfa490e51e9b5","tursoHostname","b26db1a498864203a62cfa490e51e9b5-val-town.aws-us-east-2.turso.io","tursoMeasuredAt",["D",1789477862254],"pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_98":97,"_106":102},"org",{"_98":97,"_99":100,"_101":102,"_18":53,"_103":104,"_105":24},"branch",{"_13":87,"_31":88,"_41":40,"_89":42,"_90":-5,"_91":-5,"_92":-5,"_93":-5,"_94":-5,"_95":43,"_96":97},"isOwned",23,"main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","mosadek","handle","displayName","Mo Sadek","avatar","https://lh3.googleusercontent.com/a/ACg8ocL1eT_LHhKSg5px3nXIO6eez79aZXef466qXKh2gak-0iwrvw=s96-c","tier","free","canRestrictVals","profileImageUrl","branchName","","adoptOrgId",{"_41":42,"_31":43,"_36":709,"_45":-5,"_46":24,"_47":48,"_49":48,"_50":51,"_52":-5,"_18":53,"_54":55,"_56":57,"_58":-5,"_59":-5,"_60":61,"_62":63,"_64":65,"_66":67,"_68":710,"_70":-5,"_71":72,"_73":72,"_74":75,"_76":75,"_77":75,"_78":72,"_79":72,"_80":711,"_82":712,"_84":713,"_86":24},"tree",[169,208,245,246],"files",[169,170,171,172,173,174,175,176,177,178,179,180,181,182,183,184,185,186,187,188,189,190,191,192,193,194,195,196,197,198,199,200,201,202,203,204,205,206,207,208,209,210,211,212,213,214,215,216,217,218,219,220,221,222,223,224,225,226,227,228,229,230,231,232,233,234,235,236,237,238,239,240,241,242,243,244,245,246],"counts",{"_159":61,"_160":156,"_161":61,"_162":163,"_164":165},"contents",[129,130,131,132],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},{"_41":153,"_31":154,"_29":155,"_136":-5,"_39":40,"_38":156,"_138":57,"_36":157,"_13":61,"_32":151,"_34":-5,"_23":24,"_141":-5,"_26":158},{"_41":146,"_31":147,"_29":148,"_136":-5,"_39":40,"_38":149,"_138":57,"_36":150,"_13":61,"_32":151,"_34":-5,"_23":24,"_141":-5,"_26":152},{"_41":143,"_31":27,"_29":30,"_136":-5,"_39":40,"_38":14,"_138":57,"_36":144,"_13":61,"_32":33,"_34":35,"_23":24,"_141":-5,"_26":145},{"_41":133,"_31":134,"_29":135,"_136":-5,"_39":40,"_38":137,"_138":57,"_36":139,"_13":61,"_32":33,"_34":140,"_23":24,"_141":-5,"_26":142},"89457062-6094-46a8-a821-4871983ff58f","gc_raw_manifest_v2.ts","4d905280-aaca-11f1-9e27-1607ee4eb77e","parentId",5,"latest",["D",1788792128614],"import { blob } from \"https://esm.town/v/std/blob/main.ts\";\nconst branches=[{\"name\":\"instance-affinity-wd1-finalize\",\"source_id\":\"066b4ad4-8501-42bf-b6a0-425947ac4603\",\"source_version\":9,\"paths\":[\"verify_snapshot.ts\",\"verify_snapshot_log.ts\",\"verify_http.ts\",\"tmp_recovery_search_http.ts\",\"tmp_recovery_index_http.ts\",\"tmp_python_probe.ts\",\"tmp_python_probe_http.ts\",\"tmp_latest_snapshot_task_lookup_sol.ts\",\"tmp_join_snapshot_sol_http.ts\",\"tmp_brain_cli_search_sol_http.ts\",\"snapshot_bridge_forensics.ts\",\"snapshot_bridge_forensics_http.ts\",\"rf_live_shadow_0120.ts\",\"README.md\",\"PROJECT_BRAIN_CHAT_BOOTSTRAP_V2_NO_SPRITES.md\",\"parse_status_0123_http.ts\",\"legacy_lease_horizon_test.ts\",\"legacy_active_health_test.ts\",\"instance_affinity_wd1_test.ts\",\"instance_affinity_test.ts\",\"instance_affinity_pure_runner.ts\",\"instance_affinity_gap_test.ts\",\"inspect_bridge_snapshot.ts\",\"inspect_bridge_snapshot_http.ts\",\"heartbeat_scope_test.ts\",\"heartbeat_scope_integration.ts\",\"hash_wd1.ts\",\"hash_evidence_z7p3.ts\",\"hash_branch_artifacts.ts\",\"checkpoint.ts\",\"BRAIN_VAL_BRIDGE_PROTOCOL.md\",\"brain_bridge_worker_v5_rebased_test.ts\",\"brain_bridge_worker_v5_rebased_candidate.ts\",\"brain_bridge_worker_v3_stress_test.ts\",\"brain_bridge_worker_v3_candidate.ts\",\"brain_bridge_worker_v3_candidate_test.ts\",\"brain_bridge_worker.ts\",\"brain_bridge_recovery_first_test_0120.ts\"]},{\"name\":\"instance-affinity-z7p3\",\"source_id\":\"8b742179-affd-447f-9b4e-47cdcb50c6c0\",\"source_version\":15,\"paths\":[\"verify_snapshot.ts\",\"verify_snapshot_log.ts\",\"verify_http.ts\",\"tmp_recovery_search_http.ts\",\"tmp_recovery_index_http.ts\",\"tmp_python_probe.ts\",\"tmp_python_probe_http.ts\",\"tmp_latest_snapshot_task_lookup_sol.ts\",\"tmp_join_snapshot_sol_http.ts\",\"tmp_brain_cli_search_sol_http.ts\",\"snapshot_bridge_forensics.ts\",\"snapshot_bridge_forensics_http.ts\",\"rf_live_shadow_0120.ts\",\"README.md\",\"PROJECT_BRAIN_CHAT_BOOTSTRAP_V2_NO_SPRITES.md\",\"parse_status_0123_http.ts\",\"legacy_lease_horizon_test.ts\",\"legacy_active_health_test.ts\",\"instance_affinity_test.ts\",\"instance_affinity_pure_runner.ts\",\"instance_affinity_gap_test.ts\",\"inspect_bridge_snapshot.ts\",\"inspect_bridge_snapshot_http.ts\",\"heartbeat_scope_test.ts\",\"heartbeat_scope_integration.ts\",\"hash_evidence_z7p3.ts\",\"hash_branch_artifacts.ts\",\"checkpoint.ts\",\"BRAIN_VAL_BRIDGE_PROTOCOL.md\",\"brain_bridge_worker_v5_rebased_test.ts\",\"brain_bridge_worker_v5_rebased_candidate.ts\",\"brain_bridge_worker_v3_stress_test.ts\",\"brain_bridge_worker_v3_candidate.ts\",\"brain_bridge_worker_v3_candidate_test.ts\",\"brain_bridge_worker.ts\",\"brain_bridge_recovery_first_test_0120.ts\"]}] as const;\nconst hex=(b:Uint8Array)=>[...b].map(x=>x.toString(16).padStart(2,\"0\")).join(\"\");\nasync function hashPath(rel:string){\n const u=new URL(\"./\"+rel,import.meta.url);\n const r=await fetch(u);\n const bytes=new Uint8Array(await r.arrayBuffer());\n const digest=new Uint8Array(await crypto.subtle.digest(\"SHA-256\",bytes));\n return {path:rel,http:r.status,bytes:bytes.length,sha256:hex(digest)};\n}\nconst out:any={schema:\"VAL_BRANCH_ARCHIVE_RAW_MANIFEST_V2\",classification:\"EXACT_ARCHIVE_READBACK_MANIFEST\",archive_val:\"mosadek/project-brain-branch-archive-v1\",generated_at:new Date().toISOString(),branches:[],pass:true};\nfor(const b of branches){\n const files=[] as any[];\n for(const p of b.paths) files.push(await hashPath(b.name+\"/\"+p));\n const unique=new Set(files.map(x=>x.path));\n const pass=files.length===b.paths.length&&unique.size===b.paths.length&&files.every(x=>x.http===200&&x.bytes>=0&&/^[0-9a-f]{64}$/.test(x.sha256));\n out.branches.push({name:b.name,source_id:b.source_id,source_version:b.source_version,expected_file_count:b.paths.length,readback_file_count:files.length,total_bytes:files.reduce((n,x)=>n+x.bytes,0),pass,files});\n if(!pass) out.pass=false;\n}\nout.total_files=out.branches.reduce((n:any,b:any)=>n+b.readback_file_count,0);\nout.total_bytes=out.branches.reduce((n:any,b:any)=>n+b.total_bytes,0);\nconst raw=JSON.stringify(out,null,2)+\"\\n\";\nawait blob.set(\"gc/file-ceiling-v2/ARCHIVE_RAW_MANIFEST_V2.json\",raw);\nconsole.log(raw);\nif(!out.pass) throw new Error(\"ARCHIVE_RAW_MANIFEST_FAILED\");\n","label",[134],"bc72139d-7fa4-4bfa-bedb-6baa28a6267e",["D",1788792274049],[27],"bd3a3a6c-7f22-4a9c-8d0e-13d6cd158156","instance-affinity-z7p3","01a07b80-b4d5-7124-b029-2e1fbc8ad6a4",2,["D",1788778427608],"directory",[147],"085158fb-637b-446a-b8c3-c9e8b1b0cbc5","instance-affinity-wd1-finalize","01a07b80-917a-70c9-9bdd-6b268d4d7168",1,["D",1788778418560],[154],"pulls","branches","forks","envVars",{"_166":61,"_168":61},"connections",{"_166":61,"_167":61},"count","unfilledCount","emptyCount",{"_41":153,"_31":154,"_29":155,"_136":-5,"_39":40,"_38":156,"_138":57,"_36":706,"_13":61,"_32":151,"_34":-5,"_23":24,"_141":-5,"_248":707,"_26":708},{"_41":701,"_31":502,"_29":702,"_136":155,"_39":40,"_38":513,"_138":57,"_36":703,"_13":156,"_32":20,"_34":505,"_23":24,"_141":-5,"_248":704,"_26":705},{"_41":696,"_31":495,"_29":697,"_136":155,"_39":40,"_38":513,"_138":57,"_36":698,"_13":156,"_32":20,"_34":498,"_23":24,"_141":-5,"_248":699,"_26":700},{"_41":691,"_31":488,"_29":692,"_136":155,"_39":40,"_38":513,"_138":57,"_36":693,"_13":156,"_32":20,"_34":491,"_23":24,"_141":-5,"_248":694,"_26":695},{"_41":686,"_31":481,"_29":687,"_136":155,"_39":40,"_38":513,"_138":57,"_36":688,"_13":156,"_32":33,"_34":484,"_23":24,"_141":-5,"_248":689,"_26":690},{"_41":680,"_31":474,"_29":681,"_136":155,"_39":40,"_38":513,"_138":57,"_36":682,"_13":156,"_32":273,"_34":683,"_23":24,"_141":-5,"_248":684,"_26":685},{"_41":675,"_31":467,"_29":676,"_136":155,"_39":40,"_38":513,"_138":57,"_36":677,"_13":156,"_32":33,"_34":470,"_23":24,"_141":-5,"_248":678,"_26":679},{"_41":670,"_31":460,"_29":671,"_136":155,"_39":40,"_38":513,"_138":57,"_36":672,"_13":156,"_32":33,"_34":463,"_23":24,"_141":-5,"_248":673,"_26":674},{"_41":665,"_31":453,"_29":666,"_136":155,"_39":40,"_38":513,"_138":57,"_36":667,"_13":156,"_32":33,"_34":456,"_23":24,"_141":-5,"_248":668,"_26":669},{"_41":660,"_31":446,"_29":661,"_136":155,"_39":40,"_38":513,"_138":57,"_36":662,"_13":156,"_32":33,"_34":449,"_23":24,"_141":-5,"_248":663,"_26":664},{"_41":655,"_31":439,"_29":656,"_136":155,"_39":40,"_38":513,"_138":57,"_36":657,"_13":156,"_32":33,"_34":442,"_23":24,"_141":-5,"_248":658,"_26":659},{"_41":650,"_31":432,"_29":651,"_136":155,"_39":40,"_38":513,"_138":57,"_36":652,"_13":156,"_32":273,"_34":435,"_23":24,"_141":-5,"_248":653,"_26":654},{"_41":645,"_31":425,"_29":646,"_136":155,"_39":40,"_38":513,"_138":57,"_36":647,"_13":156,"_32":33,"_34":428,"_23":24,"_141":-5,"_248":648,"_26":649},{"_41":640,"_31":418,"_29":641,"_136":155,"_39":40,"_38":513,"_138":57,"_36":642,"_13":156,"_32":33,"_34":421,"_23":24,"_141":-5,"_248":643,"_26":644},{"_41":633,"_31":634,"_29":635,"_136":155,"_39":40,"_38":513,"_138":57,"_36":636,"_13":156,"_32":33,"_34":637,"_23":24,"_141":-5,"_248":638,"_26":639},{"_41":628,"_31":411,"_29":629,"_136":155,"_39":40,"_38":513,"_138":57,"_36":630,"_13":156,"_32":33,"_34":414,"_23":24,"_141":-5,"_248":631,"_26":632},{"_41":623,"_31":404,"_29":624,"_136":155,"_39":40,"_38":513,"_138":57,"_36":625,"_13":156,"_32":33,"_34":407,"_23":24,"_141":-5,"_248":626,"_26":627},{"_41":618,"_31":397,"_29":619,"_136":155,"_39":40,"_38":513,"_138":57,"_36":620,"_13":156,"_32":33,"_34":400,"_23":24,"_141":-5,"_248":621,"_26":622},{"_41":613,"_31":390,"_29":614,"_136":155,"_39":40,"_38":513,"_138":57,"_36":615,"_13":156,"_32":273,"_34":393,"_23":24,"_141":-5,"_248":616,"_26":617},{"_41":608,"_31":383,"_29":609,"_136":155,"_39":40,"_38":513,"_138":57,"_36":610,"_13":156,"_32":33,"_34":386,"_23":24,"_141":-5,"_248":611,"_26":612},{"_41":603,"_31":376,"_29":604,"_136":155,"_39":40,"_38":513,"_138":57,"_36":605,"_13":156,"_32":33,"_34":379,"_23":24,"_141":-5,"_248":606,"_26":607},{"_41":598,"_31":369,"_29":599,"_136":155,"_39":40,"_38":513,"_138":57,"_36":600,"_13":156,"_32":33,"_34":372,"_23":24,"_141":-5,"_248":601,"_26":602},{"_41":591,"_31":592,"_29":593,"_136":155,"_39":40,"_38":513,"_138":57,"_36":594,"_13":156,"_32":33,"_34":595,"_23":24,"_141":-5,"_248":596,"_26":597},{"_41":586,"_31":362,"_29":587,"_136":155,"_39":40,"_38":513,"_138":57,"_36":588,"_13":156,"_32":33,"_34":365,"_23":24,"_141":-5,"_248":589,"_26":590},{"_41":581,"_31":355,"_29":582,"_136":155,"_39":40,"_38":513,"_138":57,"_36":583,"_13":156,"_32":33,"_34":358,"_23":24,"_141":-5,"_248":584,"_26":585},{"_41":576,"_31":348,"_29":577,"_136":155,"_39":40,"_38":513,"_138":57,"_36":578,"_13":156,"_32":273,"_34":351,"_23":24,"_141":-5,"_248":579,"_26":580},{"_41":571,"_31":341,"_29":572,"_136":155,"_39":40,"_38":513,"_138":57,"_36":573,"_13":156,"_32":33,"_34":344,"_23":24,"_141":-5,"_248":574,"_26":575},{"_41":566,"_31":334,"_29":567,"_136":155,"_39":40,"_38":513,"_138":57,"_36":568,"_13":156,"_32":33,"_34":337,"_23":24,"_141":-5,"_248":569,"_26":570},{"_41":561,"_31":327,"_29":562,"_136":155,"_39":40,"_38":513,"_138":57,"_36":563,"_13":156,"_32":273,"_34":330,"_23":24,"_141":-5,"_248":564,"_26":565},{"_41":556,"_31":320,"_29":557,"_136":155,"_39":40,"_38":513,"_138":57,"_36":558,"_13":156,"_32":273,"_34":323,"_23":24,"_141":-5,"_248":559,"_26":560},{"_41":551,"_31":313,"_29":552,"_136":155,"_39":40,"_38":513,"_138":57,"_36":553,"_13":156,"_32":273,"_34":316,"_23":24,"_141":-5,"_248":554,"_26":555},{"_41":546,"_31":306,"_29":547,"_136":155,"_39":40,"_38":513,"_138":57,"_36":548,"_13":156,"_32":273,"_34":309,"_23":24,"_141":-5,"_248":549,"_26":550},{"_41":541,"_31":299,"_29":542,"_136":155,"_39":40,"_38":513,"_138":57,"_36":543,"_13":156,"_32":33,"_34":302,"_23":24,"_141":-5,"_248":544,"_26":545},{"_41":536,"_31":292,"_29":537,"_136":155,"_39":40,"_38":513,"_138":57,"_36":538,"_13":156,"_32":273,"_34":295,"_23":24,"_141":-5,"_248":539,"_26":540},{"_41":531,"_31":285,"_29":532,"_136":155,"_39":40,"_38":513,"_138":57,"_36":533,"_13":156,"_32":273,"_34":288,"_23":24,"_141":-5,"_248":534,"_26":535},{"_41":526,"_31":278,"_29":527,"_136":155,"_39":40,"_38":513,"_138":57,"_36":528,"_13":156,"_32":273,"_34":281,"_23":24,"_141":-5,"_248":529,"_26":530},{"_41":522,"_31":270,"_29":55,"_136":155,"_39":40,"_38":513,"_138":57,"_36":523,"_13":156,"_32":273,"_34":274,"_23":24,"_141":-5,"_248":524,"_26":525},{"_41":517,"_31":263,"_29":518,"_136":155,"_39":40,"_38":513,"_138":57,"_36":519,"_13":156,"_32":33,"_34":266,"_23":24,"_141":-5,"_248":520,"_26":521},{"_41":511,"_31":255,"_29":512,"_136":155,"_39":40,"_38":513,"_138":57,"_36":514,"_13":156,"_32":33,"_34":259,"_23":24,"_141":-5,"_248":515,"_26":516},{"_41":146,"_31":147,"_29":148,"_136":-5,"_39":40,"_38":149,"_138":57,"_36":508,"_13":61,"_32":151,"_34":-5,"_23":24,"_141":-5,"_248":509,"_26":510},{"_41":501,"_31":502,"_29":503,"_136":148,"_39":40,"_38":257,"_138":57,"_36":504,"_13":156,"_32":20,"_34":505,"_23":24,"_141":-5,"_248":506,"_26":507},{"_41":494,"_31":495,"_29":496,"_136":148,"_39":40,"_38":257,"_138":57,"_36":497,"_13":156,"_32":20,"_34":498,"_23":24,"_141":-5,"_248":499,"_26":500},{"_41":487,"_31":488,"_29":489,"_136":148,"_39":40,"_38":257,"_138":57,"_36":490,"_13":156,"_32":20,"_34":491,"_23":24,"_141":-5,"_248":492,"_26":493},{"_41":480,"_31":481,"_29":482,"_136":148,"_39":40,"_38":257,"_138":57,"_36":483,"_13":156,"_32":33,"_34":484,"_23":24,"_141":-5,"_248":485,"_26":486},{"_41":473,"_31":474,"_29":475,"_136":148,"_39":40,"_38":257,"_138":57,"_36":476,"_13":156,"_32":273,"_34":477,"_23":24,"_141":-5,"_248":478,"_26":479},{"_41":466,"_31":467,"_29":468,"_136":148,"_39":40,"_38":257,"_138":57,"_36":469,"_13":156,"_32":33,"_34":470,"_23":24,"_141":-5,"_248":471,"_26":472},{"_41":459,"_31":460,"_29":461,"_136":148,"_39":40,"_38":257,"_138":57,"_36":462,"_13":156,"_32":33,"_34":463,"_23":24,"_141":-5,"_248":464,"_26":465},{"_41":452,"_31":453,"_29":454,"_136":148,"_39":40,"_38":257,"_138":57,"_36":455,"_13":156,"_32":33,"_34":456,"_23":24,"_141":-5,"_248":457,"_26":458},{"_41":445,"_31":446,"_29":447,"_136":148,"_39":40,"_38":257,"_138":57,"_36":448,"_13":156,"_32":33,"_34":449,"_23":24,"_141":-5,"_248":450,"_26":451},{"_41":438,"_31":439,"_29":440,"_136":148,"_39":40,"_38":257,"_138":57,"_36":441,"_13":156,"_32":33,"_34":442,"_23":24,"_141":-5,"_248":443,"_26":444},{"_41":431,"_31":432,"_29":433,"_136":148,"_39":40,"_38":257,"_138":57,"_36":434,"_13":156,"_32":273,"_34":435,"_23":24,"_141":-5,"_248":436,"_26":437},{"_41":424,"_31":425,"_29":426,"_136":148,"_39":40,"_38":257,"_138":57,"_36":427,"_13":156,"_32":33,"_34":428,"_23":24,"_141":-5,"_248":429,"_26":430},{"_41":417,"_31":418,"_29":419,"_136":148,"_39":40,"_38":257,"_138":57,"_36":420,"_13":156,"_32":33,"_34":421,"_23":24,"_141":-5,"_248":422,"_26":423},{"_41":410,"_31":411,"_29":412,"_136":148,"_39":40,"_38":257,"_138":57,"_36":413,"_13":156,"_32":33,"_34":414,"_23":24,"_141":-5,"_248":415,"_26":416},{"_41":403,"_31":404,"_29":405,"_136":148,"_39":40,"_38":257,"_138":57,"_36":406,"_13":156,"_32":33,"_34":407,"_23":24,"_141":-5,"_248":408,"_26":409},{"_41":396,"_31":397,"_29":398,"_136":148,"_39":40,"_38":257,"_138":57,"_36":399,"_13":156,"_32":33,"_34":400,"_23":24,"_141":-5,"_248":401,"_26":402},{"_41":389,"_31":390,"_29":391,"_136":148,"_39":40,"_38":257,"_138":57,"_36":392,"_13":156,"_32":273,"_34":393,"_23":24,"_141":-5,"_248":394,"_26":395},{"_41":382,"_31":383,"_29":384,"_136":148,"_39":40,"_38":257,"_138":57,"_36":385,"_13":156,"_32":33,"_34":386,"_23":24,"_141":-5,"_248":387,"_26":388},{"_41":375,"_31":376,"_29":377,"_136":148,"_39":40,"_38":257,"_138":57,"_36":378,"_13":156,"_32":33,"_34":379,"_23":24,"_141":-5,"_248":380,"_26":381},{"_41":368,"_31":369,"_29":370,"_136":148,"_39":40,"_38":257,"_138":57,"_36":371,"_13":156,"_32":33,"_34":372,"_23":24,"_141":-5,"_248":373,"_26":374},{"_41":361,"_31":362,"_29":363,"_136":148,"_39":40,"_38":257,"_138":57,"_36":364,"_13":156,"_32":33,"_34":365,"_23":24,"_141":-5,"_248":366,"_26":367},{"_41":354,"_31":355,"_29":356,"_136":148,"_39":40,"_38":257,"_138":57,"_36":357,"_13":156,"_32":33,"_34":358,"_23":24,"_141":-5,"_248":359,"_26":360},{"_41":347,"_31":348,"_29":349,"_136":148,"_39":40,"_38":257,"_138":57,"_36":350,"_13":156,"_32":273,"_34":351,"_23":24,"_141":-5,"_248":352,"_26":353},{"_41":340,"_31":341,"_29":342,"_136":148,"_39":40,"_38":257,"_138":57,"_36":343,"_13":156,"_32":33,"_34":344,"_23":24,"_141":-5,"_248":345,"_26":346},{"_41":333,"_31":334,"_29":335,"_136":148,"_39":40,"_38":257,"_138":57,"_36":336,"_13":156,"_32":33,"_34":337,"_23":24,"_141":-5,"_248":338,"_26":339},{"_41":326,"_31":327,"_29":328,"_136":148,"_39":40,"_38":257,"_138":57,"_36":329,"_13":156,"_32":273,"_34":330,"_23":24,"_141":-5,"_248":331,"_26":332},{"_41":319,"_31":320,"_29":321,"_136":148,"_39":40,"_38":257,"_138":57,"_36":322,"_13":156,"_32":273,"_34":323,"_23":24,"_141":-5,"_248":324,"_26":325},{"_41":312,"_31":313,"_29":314,"_136":148,"_39":40,"_38":257,"_138":57,"_36":315,"_13":156,"_32":273,"_34":316,"_23":24,"_141":-5,"_248":317,"_26":318},{"_41":305,"_31":306,"_29":307,"_136":148,"_39":40,"_38":257,"_138":57,"_36":308,"_13":156,"_32":273,"_34":309,"_23":24,"_141":-5,"_248":310,"_26":311},{"_41":298,"_31":299,"_29":300,"_136":148,"_39":40,"_38":257,"_138":57,"_36":301,"_13":156,"_32":33,"_34":302,"_23":24,"_141":-5,"_248":303,"_26":304},{"_41":291,"_31":292,"_29":293,"_136":148,"_39":40,"_38":257,"_138":57,"_36":294,"_13":156,"_32":273,"_34":295,"_23":24,"_141":-5,"_248":296,"_26":297},{"_41":284,"_31":285,"_29":286,"_136":148,"_39":40,"_38":257,"_138":57,"_36":287,"_13":156,"_32":273,"_34":288,"_23":24,"_141":-5,"_248":289,"_26":290},{"_41":277,"_31":278,"_29":279,"_136":148,"_39":40,"_38":257,"_138":57,"_36":280,"_13":156,"_32":273,"_34":281,"_23":24,"_141":-5,"_248":282,"_26":283},{"_41":269,"_31":270,"_29":271,"_136":148,"_39":40,"_38":257,"_138":57,"_36":272,"_13":156,"_32":273,"_34":274,"_23":24,"_141":-5,"_248":275,"_26":276},{"_41":262,"_31":263,"_29":264,"_136":148,"_39":40,"_38":257,"_138":57,"_36":265,"_13":156,"_32":33,"_34":266,"_23":24,"_141":-5,"_248":267,"_26":268},{"_41":254,"_31":255,"_29":256,"_136":148,"_39":40,"_38":257,"_138":57,"_36":258,"_13":156,"_32":33,"_34":259,"_23":24,"_141":-5,"_248":260,"_26":261},{"_41":143,"_31":27,"_29":30,"_136":-5,"_39":40,"_38":14,"_138":57,"_36":251,"_13":61,"_32":33,"_34":35,"_23":24,"_141":-5,"_248":252,"_26":253},{"_41":133,"_31":134,"_29":135,"_136":-5,"_39":40,"_38":137,"_138":57,"_36":247,"_13":61,"_32":33,"_34":140,"_23":24,"_141":-5,"_248":249,"_26":250},["D",1788792128614],"children",[],[134],["D",1788792274049],[],[27],"33aa50ac-db17-4f0a-b657-53274ed364c5","verify_snapshot_log.ts","01a07b80-b4d5-7124-b029-353a14258ffe",4,["D",1788791971867],"import { blob } from \"https://esm.town/v/std/blob/main.ts\";\n\nasync function sha256Hex(bytes: Uint8Array): Promise {\n const digest = await crypto.subtle.digest(\"SHA-256\", bytes);\n return [...new Uint8Array(digest)].map(b => b.toString(16).padStart(2,\"0\")).join(\"\");\n}\n\nexport default async function () {\n const key = \"snapshots/brain_snapshot_g59_c181c088187c09cc.json\";\n const res = await blob.get(key);\n const bytes = new Uint8Array(await res.arrayBuffer());\n const parsed = JSON.parse(new TextDecoder().decode(bytes));\n const out = {\n key,\n size: bytes.length,\n sha256: await sha256Hex(bytes),\n generation: parsed.snapshot?.generation,\n event_head_hash: parsed.snapshot?.event_head_hash,\n event_count: parsed.snapshot?.event_count,\n claim_count: parsed.snapshot?.claim_count,\n agent_ids: parsed.snapshot?.agents?.map((a:any)=>a.id).sort(),\n };\n console.log(JSON.stringify(out));\n return out;\n}",[],[147,255],"8eba8b39-2539-4730-a6f9-f77c0898ac38","verify_snapshot.ts","01a07b80-b4d5-7124-b029-30a324842068",["D",1788791971867],"import { blob } from \"https://esm.town/v/std/blob/main.ts\";\n\nasync function sha256Hex(bytes: Uint8Array): Promise {\n const digest = await crypto.subtle.digest(\"SHA-256\", bytes);\n return [...new Uint8Array(digest)].map(b => b.toString(16).padStart(2,\"0\")).join(\"\");\n}\n\nexport default async function () {\n const key = \"snapshots/brain_snapshot_g59_c181c088187c09cc.json\";\n const res = await blob.get(key);\n const ab = await res.arrayBuffer();\n const bytes = new Uint8Array(ab);\n const sha256 = await sha256Hex(bytes);\n const text = new TextDecoder().decode(bytes);\n const parsed = JSON.parse(text);\n return {\n key,\n size: bytes.length,\n sha256,\n generation: parsed.snapshot?.generation,\n event_head_hash: parsed.snapshot?.event_head_hash,\n event_count: parsed.snapshot?.event_count,\n claim_count: parsed.snapshot?.claim_count,\n agent_ids: parsed.snapshot?.agents?.map((a:any)=>a.id).sort(),\n };\n}",[],[147,263],"12c503d8-ebb7-43c9-b2d6-87061ec0325d","verify_http.ts","01a07b80-b4d6-73c0-ae84-dca7ec1f1384",["D",1788791971867],"http","import { blob } from \"https://esm.town/v/std/blob/main.ts\";\n\nasync function sha256Hex(bytes: Uint8Array): Promise {\n const digest = await crypto.subtle.digest(\"SHA-256\", bytes);\n return [...new Uint8Array(digest)].map(b => b.toString(16).padStart(2,\"0\")).join(\"\");\n}\n\nexport default async function (_req: Request) {\n const key = \"snapshots/brain_snapshot_g59_c181c088187c09cc.json\";\n const res = await blob.get(key);\n const bytes = new Uint8Array(await res.arrayBuffer());\n const parsed = JSON.parse(new TextDecoder().decode(bytes));\n const out = {\n key,\n size: bytes.length,\n sha256: await sha256Hex(bytes),\n generation: parsed.snapshot?.generation,\n event_head_hash: parsed.snapshot?.event_head_hash,\n event_count: parsed.snapshot?.event_count,\n claim_count: parsed.snapshot?.claim_count,\n agent_ids: parsed.snapshot?.agents?.map((a:any)=>a.id).sort(),\n };\n return Response.json(out);\n}",[],[147,270],"69e94783-0c94-430b-933c-a5cde1de1ce3","tmp_recovery_search_http.ts","01a07b80-b4d6-73c0-ae84-e158d0a6fa3b",["D",1788791971867],"import { blob } from \"https://esm.town/v/std/blob/main.ts\";\nfunction gen(k:string){const m=k.match(/^snapshots\\/brain_snapshot_g(\\d+)_/);return m?Number(m[1]):-1;}\nexport default async function(req:Request){\n const q=new URL(req.url).searchParams.get(\"q\")||\"proxy|http|server|worker|bridge|checkpoint|snapshot|listen|serve\";\n const re=new RegExp(q,\"i\");\n const es:any[]=await blob.list(\"snapshots/brain_snapshot_g\"); es.sort((a,b)=>gen(b.key)-gen(a.key)); const d=JSON.parse(await (await blob.get(es[0].key)).text());\n const out:any={generation:d.snapshot?.generation,files:{}};\n for(const r of d.recovery_files||[]){const lines=String(r.content_utf8||\"\").split(\"\\n\"); const hits:any[]=[]; for(let i=0;igen(b.key)-gen(a.key)); const e=es[0];\n const d=JSON.parse(await (await blob.get(e.key)).text()); const rec=d.recovery_files||[];\n return Response.json({key:e.key,generation:d.snapshot?.generation,count:rec.length,files:rec.map((r:any)=>({path:r.logical_path,size:r.size,sha256:r.sha256}))});\n}",[],[147,285],"b10052db-4189-4791-8bc8-d9eb447609df","tmp_python_probe_http.ts","01a07b80-b4d6-73c0-ae84-ec2cd84d7f01",["D",1788791971867],"export default async function(_req:Request) {\n try {\n const p=new Deno.Command(\"python3\",{args:[\"-c\",\"import sys; print(sys.version); print('PYTHON_OK')\"],stdout:\"piped\",stderr:\"piped\"});\n const o=await p.output();\n return Response.json({ok:o.success,code:o.code,stdout:new TextDecoder().decode(o.stdout),stderr:new TextDecoder().decode(o.stderr)});\n } catch(e) { return Response.json({ok:false,error:String(e)}); }\n}",[],[147,292],"5f8ae92a-001d-4a93-aca2-82593e246f60","tmp_python_probe.ts","01a07b80-b4d6-73c0-ae84-e8d7e08c7ee8",["D",1788791971867],"export default async function() {\n try {\n const p = new Deno.Command(\"python3\",{args:[\"-c\",\"import sys; print(sys.version); print('PYTHON_OK')\"],stdout:\"piped\",stderr:\"piped\"});\n const o=await p.output();\n const out={ok:o.success,code:o.code,stdout:new TextDecoder().decode(o.stdout),stderr:new TextDecoder().decode(o.stderr)}; console.log(JSON.stringify(out)); return out;\n } catch(e) { const out={ok:false,error:String(e)}; console.log(JSON.stringify(out)); return out; }\n}",[],[147,299],"6ebbedb4-26e5-4146-9066-bf51b558ce1b","tmp_latest_snapshot_task_lookup_sol.ts","01a07b80-b4d6-73c0-ae84-f1939463e92c",["D",1788791971867],"import { blob } from \"https://esm.town/v/std/blob/main.ts\";\nexport default async function(req:Request){\n const u=new URL(req.url); const q=(u.searchParams.get(\"q\")||\"\").toLowerCase();\n const es:any[]=await blob.list(\"snapshots/brain_snapshot_g\");\n const gen=(k:string)=>Number(k.match(/^snapshots\\/brain_snapshot_g(\\d+)_/)?.[1]||-1);\n es.sort((a,b)=>gen(b.key)-gen(a.key));\n const e=es[0]; const d=JSON.parse(await (await blob.get(e.key)).text());\n const tasks=(d.snapshot?.tasks||[]).filter((x:any)=>JSON.stringify(x).toLowerCase().includes(q)).slice(0,30);\n return Response.json({snapshot:e.key,generation:d.snapshot?.generation,event_head_hash:d.snapshot?.event_head_hash,q,tasks});\n}",[],[147,306],"d44bad0d-4386-4876-9297-f2cff838634f","tmp_join_snapshot_sol_http.ts","01a07b80-b4d6-73c0-ae84-f5841f5156d9",["D",1788791971867],"import { blob } from \"https://esm.town/v/std/blob/main.ts\";\nexport default async function(){\n const es:any[]=await blob.list(\"snapshots/brain_snapshot_g\");\n const gen=(k:string)=>Number(k.match(/^snapshots\\/brain_snapshot_g(\\d+)_/)?.[1]||-1);\n es.sort((a,b)=>gen(b.key)-gen(a.key));\n const e=es[0];\n const d=JSON.parse(await (await blob.get(e.key)).text());\n const r=(d.recovery_files||[]).find((x:any)=>x.logical_path===\"JOIN_PROTOCOL.md\");\n if(!r) return new Response(\"NOT_FOUND\",{status:404});\n return new Response(r.content_utf8,{headers:{\"content-type\":\"text/markdown; charset=utf-8\",\"x-snapshot-key\":e.key,\"x-join-sha256\":r.sha256}});\n}",[],[147,313],"cb5de597-4014-4b55-9c39-81594c3c2ce0","tmp_brain_cli_search_sol_http.ts","01a07b80-b4d6-73c0-ae84-f83bbdefd841",["D",1788791971867],"import { blob } from \"https://esm.town/v/std/blob/main.ts\";\nexport default async function(req:Request){\n const u=new URL(req.url); const q=u.searchParams.get(\"q\")||\"\"; const ctx=Math.min(20,Math.max(0,Number(u.searchParams.get(\"ctx\")||8)));\n const es:any[]=await blob.list(\"snapshots/brain_snapshot_g\"); const gen=(k:string)=>Number(k.match(/^snapshots\\/brain_snapshot_g(\\d+)_/)?.[1]||-1); es.sort((a,b)=>gen(b.key)-gen(a.key));\n const e=es[0]; const d=JSON.parse(await (await blob.get(e.key)).text()); const r=(d.recovery_files||[]).find((x:any)=>x.logical_path===\"brain.py\"); if(!r) return Response.json({error:\"NO_BRAIN\"});\n const lines=String(r.content_utf8).split(\"\\n\"); const hits:number[]=[]; lines.forEach((s,i)=>{if(s.includes(q))hits.push(i)});\n const windows=hits.slice(0,30).map(i=>({line:i+1,text:lines.slice(Math.max(0,i-ctx),Math.min(lines.length,i+ctx+1)).map((s,j)=>String(Math.max(0,i-ctx)+j+1).padStart(5)+\"|\"+s).join(\"\\n\")}));\n return Response.json({snapshot:e.key,generation:d.snapshot?.generation,brain_sha256:r.sha256,q,hits:hits.length,windows});\n}",[],[147,320],"bf6842ad-bf8e-461b-b50b-50bcfbdbb7f4","snapshot_bridge_forensics_http.ts","01a07b80-b4d6-73c0-ae85-037d609bb0fb",["D",1788791971867],"import { blob } from \"https://esm.town/v/std/blob/main.ts\";\nexport default async function(req: Request): Promise {\n const key=\"snapshots/brain_snapshot_g1235_08f571acc715207e.json\";\n const doc:any=JSON.parse(await (await blob.get(key)).text());\n const terms=[\"brain_proxy\",\"proxy\",\"reverse bridge\",\"brain bridge\",\"val bridge\",\"ed25519\",\"signed http\",\"signed request\"];\n const has=(x:any)=>terms.some(t=>JSON.stringify(x).toLowerCase().includes(t));\n const events=(doc.events||[]).filter(has).map((e:any)=>({id:e.id,type:e.type,task_id:e.task_id,agent_id:e.agent_id,payload_json:e.payload_json})).slice(-30);\n const tasks=(doc.snapshot?.tasks||[]).filter(has).map((t:any)=>({id:t.id,state:t.state,dedupe_key:t.dedupe_key,success_condition:t.success_condition,context_manifest:t.context_manifest,result_event_id:t.result_event_id})).slice(-30);\n return Response.json({generation:doc.snapshot?.generation,events,tasks});\n}",[],[147,327],"6ad99bb9-4b0b-4118-932d-0a162f2d230e","snapshot_bridge_forensics.ts","01a07b80-b4d6-73c0-ae84-ff40c19d0b67",["D",1788791971867],"import { blob } from \"https://esm.town/v/std/blob/main.ts\";\n\nexport default async function () {\n const key = \"snapshots/brain_snapshot_g1235_08f571acc715207e.json\";\n const res = await blob.get(key);\n const text = await res.text();\n const doc:any = JSON.parse(text);\n const terms = [\"brain_proxy\",\"proxy\",\"reverse bridge\",\"brain bridge\",\"val bridge\",\"ed25519\",\"signed http\",\"signed request\"];\n const has = (s:string) => terms.some(t => s.toLowerCase().includes(t));\n const events = (doc.events || []).filter((e:any) => has(JSON.stringify(e))).map((e:any)=>({\n id:e.id,type:e.type,task_id:e.task_id,agent_id:e.agent_id,workstream:e.workstream,\n payload_json:String(e.payload_json||\"\").slice(0,2600)\n })).slice(-80);\n const tasks = (doc.snapshot?.tasks || []).filter((t:any)=>has(JSON.stringify(t))).map((t:any)=>({\n id:t.id,state:t.state,priority:t.priority,requires_json:t.requires_json,depends_json:t.depends_json,\n dedupe_key:t.dedupe_key,success_condition:t.success_condition,context_manifest:t.context_manifest,\n result_event_id:t.result_event_id,lease_owner:t.lease_owner,updated_at:t.updated_at\n })).slice(-60);\n return { key, generation:doc.snapshot?.generation, events, tasks };\n}",[],[147,334],"8c939e30-b6b6-4bc6-babb-a26037c9ad5e","rf_live_shadow_0120.ts","01a07b80-b4d6-73c0-ae85-051c75f173b4",["D",1788791971867],"import { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\nimport { leaseOneSql } from \"./brain_bridge_worker.ts\";\nconst T=\"bridge_rf_shadow_0120\";\nawait sqlite.execute(`DROP TABLE IF EXISTS ${T}`);\nawait sqlite.execute(`CREATE TABLE ${T}(\n id TEXT PRIMARY KEY, priority REAL NOT NULL DEFAULT 0, op TEXT NOT NULL,\n payload_json TEXT NOT NULL, state TEXT NOT NULL DEFAULT 'READY',\n lease_owner TEXT, lease_expires_at TEXT, result_json TEXT, error_json TEXT,\n created_at TEXT NOT NULL, updated_at TEXT NOT NULL\n)`);\ntry{\n await sqlite.execute(`INSERT INTO ${T}(id,priority,op,payload_json,state,lease_owner,lease_expires_at,result_json,error_json,created_at,updated_at)\n SELECT id,priority,op,payload_json,state,lease_owner,lease_expires_at,result_json,error_json,created_at,updated_at\n FROM brain_bridge_jobs WHERE state='READY'`);\n const before:any=await sqlite.execute(`SELECT COUNT(*) AS n,MIN(created_at) AS oldest FROM ${T}`);\n const r:any=await sqlite.execute({sql:leaseOneSql(T),args:[\"shadow-worker-0120\",\"shadow-worker-0120\"]});\n const chosen=r.rows?.[0]||null;\n const ok=chosen?.id===\"chat-20260906-0112-recover-stale-kernel-r2\";\n console.log(JSON.stringify({ok,classification:\"LIVE_QUEUE_SHADOW_RECOVERY_FIRST\",ready_count:before.rows?.[0]?.n,oldest_ready_at:before.rows?.[0]?.oldest,chosen},null,2));\n if(!ok) throw new Error(\"WRONG_LIVE_QUEUE_SELECTION:\"+JSON.stringify(chosen));\n}finally{\n await sqlite.execute(`DROP TABLE IF EXISTS ${T}`);\n}",[],[147,341],"c5ad4963-1a76-4706-8d97-d219f1ace583","parse_status_0123_http.ts","01a07b80-b4d6-73c0-ae85-10eda886a191",["D",1788791971867],"import { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\nexport default async function(req:Request){\n const id=new URL(req.url).searchParams.get(\"id\")||\"chat-gpt56sol-20260906-0123-status\";\n const r:any=await sqlite.execute({sql:\"SELECT result_json,state FROM brain_bridge_jobs WHERE id=?\",args:[id]});\n const row=r.rows?.[0]; if(!row)return Response.json({ok:false,error:\"NOT_FOUND\"},{status:404});\n const outer=JSON.parse(String(row.result_json||\"null\"));\n const s=JSON.parse(String(outer?.stdout||\"{}\").trim());\n const want=new Set([\n \"BRAIN-VAL-BRIDGE-HOTPATH-MIGRATION-V1\",\n \"BRAIN-VAL-BRIDGE-LEASE-TIMEOUT-LIVENESS-V1-20260906\",\n \"BRAIN-VAL-BRIDGE-PROOF-V1\",\n \"BRAIN-VAL-BRIDGE-V3-INDEPENDENT-FALSIFICATION-20260906\"\n ]);\n const tasks=(s.tasks||[]);\n return Response.json({\n ok:true,queue_state:row.state,generation:s.generation,event_head_hash:s.event_head_hash,event_count:s.event_count,\n kernel_version:s.kernel_version,schema_version:s.schema_version,durability:s.durability,\n workstreams:(s.workstreams||[]).map((w:any)=>({id:w.id,head_generation:w.head_generation,updated_at:w.updated_at,mission:w.mission})),\n focus_tasks:tasks.filter((t:any)=>want.has(t.id)).map((t:any)=>({id:t.id,state:t.state,workstream:t.workstream,priority:t.priority,lease_owner:t.lease_owner,lease_expires_at:t.lease_expires_at,result_event_id:t.result_event_id,depends_json:t.depends_json,requires_json:t.requires_json,dedupe_key:t.dedupe_key,updated_at:t.updated_at})),\n global_ready:tasks.filter((t:any)=>t.workstream===\"global\"&&t.state===\"READY\").sort((a:any,b:any)=>(b.priority||0)-(a.priority||0)).slice(0,20).map((t:any)=>({id:t.id,priority:t.priority,requires_json:t.requires_json,depends_json:t.depends_json,dedupe_key:t.dedupe_key,assigned_agent:t.assigned_agent})),\n global_leased:tasks.filter((t:any)=>t.workstream===\"global\"&&t.state===\"LEASED\").map((t:any)=>({id:t.id,priority:t.priority,lease_owner:t.lease_owner,lease_expires_at:t.lease_expires_at,requires_json:t.requires_json}))\n });\n}",[],[147,348],"740d0d4e-ed91-4641-9c46-91797a3f01c0","legacy_lease_horizon_test.ts","01a07b80-b4d6-73c0-ae85-15ac162f4e2a",["D",1788791971867],"import { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\nimport { LEASE_SECONDS, healthHttpStatus, legacyLeaseRiskLeases } from \"./brain_bridge_worker.ts\";\n\nconst T=\"legacy_lease_horizon_z7p3_\"+crypto.randomUUID().replaceAll(\"-\",\"\");\nconst out:any={tests:[],failures:[]};\nconst ok=(name:string,cond:boolean,detail:any={})=>{out.tests.push({name,ok:!!cond,detail});if(!cond)out.failures.push(name)};\n\nawait sqlite.execute(`CREATE TABLE ${T}(\n endpoint_host TEXT NOT NULL,worker_id TEXT NOT NULL,instance_id TEXT NOT NULL,last_poll_at TEXT\n)`);\ntry{\n const worker=\"project-brain-live-v1-worker-v2\";\n await sqlite.execute({sql:`INSERT INTO ${T} VALUES\n ('main.example',?,'LEGACY_UNATTESTED_INSTANCE',datetime('now','-100 seconds')),\n ('main.example',?,'attested-new',datetime('now'))`,args:[worker,worker]});\n const recent:any=await sqlite.execute({sql:`SELECT COUNT(*) AS n FROM ${T}\n WHERE endpoint_host='main.example' AND worker_id=? AND last_poll_at>=datetime('now','-90 seconds')`,args:[worker]});\n const risk:any=await sqlite.execute({sql:`SELECT COUNT(*) AS n FROM ${T}\n WHERE endpoint_host='main.example' AND worker_id=? AND instance_id='LEGACY_UNATTESTED_INSTANCE'\n AND last_poll_at>=datetime('now','-' || ? || ' seconds')`,args:[worker,LEASE_SECONDS]});\n const recentCount=Number(recent.rows?.[0]?.n||0);\n const riskCount=Number(risk.rows?.[0]?.n||0);\n const legacyActive=legacyLeaseRiskLeases(1,riskCount);\n ok(\"legacy_100s_not_recent_but_within_180s_lease_horizon\",recentCount===1 && riskCount===1,{recentCount,riskCount});\n ok(\"live_legacy_origin_risk_fails_health_closed\",healthHttpStatus(\"HEALTHY\",0,0,legacyActive,recentCount)===503,{legacyActive,recentCount});\n\n ok(\"legacy_risk_without_active_lease_does_not_false_fail\",legacyLeaseRiskLeases(0,riskCount)===0);\n ok(\"no_legacy_risk_with_active_attested_lease_can_be_healthy\",\n healthHttpStatus(\"HEALTHY\",0,0,legacyLeaseRiskLeases(1,0),1)===200);\n\n await sqlite.execute({sql:`UPDATE ${T} SET last_poll_at=datetime('now','-181 seconds')\n WHERE endpoint_host='main.example' AND instance_id='LEGACY_UNATTESTED_INSTANCE'`});\n const past:any=await sqlite.execute({sql:`SELECT COUNT(*) AS n FROM ${T}\n WHERE endpoint_host='main.example' AND worker_id=? AND instance_id='LEGACY_UNATTESTED_INSTANCE'\n AND last_poll_at>=datetime('now','-' || ? || ' seconds')`,args:[worker,LEASE_SECONDS]});\n ok(\"legacy_older_than_max_lease_horizon_no_longer_counts\",Number(past.rows?.[0]?.n||0)===0,{row:past.rows?.[0]});\n\n out.summary={passed:out.tests.filter((x:any)=>x.ok).length,failed:out.failures.length,total:out.tests.length};\n console.log(JSON.stringify(out,null,2));\n}finally{\n await sqlite.execute(`DROP TABLE IF EXISTS ${T}`);\n}\nif(out.failures.length)throw new Error(\"LEGACY_LEASE_HORIZON_TEST_FAILURE:\"+out.failures.join(\",\"));",[],[147,355],"73472787-d561-4069-8363-9c291e1ada11","legacy_active_health_test.ts","01a07b80-b4d6-73c0-ae85-1ad259c4312b",["D",1788791971867],"import { healthHttpStatus } from \"./brain_bridge_worker.ts\";\nfunction assert(c:boolean,m:string){if(!c)throw new Error(m)}\nexport default function(){\n assert(healthHttpStatus(\"HEALTHY\",0,0,0)===200,\"healthy idle must remain 200\");\n assert(healthHttpStatus(\"HEALTHY\",0,0,1)===503,\"legacy unattested active lease must fail closed\");\n assert(healthHttpStatus(\"HEALTHY\",0,0,3)===503,\"multiple legacy unattested active leases must fail closed\");\n assert(healthHttpStatus(\"DEGRADED\",0,0,0)===503,\"degraded remains 503\");\n assert(healthHttpStatus(\"HEALTHY\",1,0,0)===503,\"duplicate remains 503\");\n assert(healthHttpStatus(\"HEALTHY\",0,1,0)===503,\"expired remains 503\");\n return {ok:true,assertions:6,classification:\"LEGACY_ACTIVE_LEASE_FAIL_CLOSED_PASS\"};\n}",[],[147,362],"0138fa16-0f0b-4e09-8c2b-64253cc93227","instance_affinity_test.ts","01a07b80-b4d6-73c0-ae85-1d364d19bc39",["D",1788791971867],"import { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\nimport { isAttestedInstance, leaseOneSql } from \"./brain_bridge_worker.ts\";\nconst T=\"bridge_instance_affinity_test_0140\";\nconst out:any={tests:[],failures:[]};\nconst ok=(name:string,cond:boolean,detail:any={})=>{out.tests.push({name,ok:!!cond,detail});if(!cond)out.failures.push(name)};\nconst ex=(sql:string,args:any[]=[])=>sqlite.execute({sql,args});\nawait sqlite.execute(`DROP TABLE IF EXISTS ${T}`);\nawait sqlite.execute(`CREATE TABLE ${T}(\n id TEXT PRIMARY KEY,priority REAL NOT NULL DEFAULT 0,op TEXT NOT NULL,payload_json TEXT NOT NULL,\n state TEXT NOT NULL DEFAULT 'READY',lease_owner TEXT,lease_expires_at TEXT,result_json TEXT,error_json TEXT,\n created_at TEXT NOT NULL,updated_at TEXT NOT NULL\n)`);\ntry{\n ok(\"legacy_not_attested\",!isAttestedInstance(\"LEGACY_UNATTESTED_INSTANCE\"));\n ok(\"uuid_attested\",isAttestedInstance(\"c7d7f290-2f43-4fda-a997-e2133962ac83\"));\n const ordinary=JSON.stringify({args:[\"verify-chain\"],timeout:60});\n const recover=JSON.stringify({args:[\"recover-stale\"],timeout:60});\n\n await ex(`INSERT INTO ${T}(id,priority,op,payload_json,state,created_at,updated_at) VALUES\n ('recover',1e300,'brain',?,'READY','2026-01-01 00:00:00','2026-01-01 00:00:00'),\n ('ordinary',1e300,'brain',?,'READY','2026-01-01 00:00:01','2026-01-01 00:00:01')`,[recover,ordinary]);\n let r:any=await ex(leaseOneSql(T,false),[\"worker\",\"worker\"]);\n ok(\"legacy_skips_recovery_and_leases_ordinary\",r.rows?.[0]?.id===\"ordinary\",{row:r.rows?.[0]});\n\n await ex(`DELETE FROM ${T}`);\n await ex(`INSERT INTO ${T}(id,priority,op,payload_json,state,created_at,updated_at)\n VALUES('recover',1e300,'brain',?,'READY','2026-01-01 00:00:00','2026-01-01 00:00:00')`,[recover]);\n r=await ex(leaseOneSql(T,false),[\"worker\",\"worker\"]);\n ok(\"legacy_with_only_recovery_gets_no_job\",(r.rows?.length||0)===0,{rows:r.rows});\n\n r=await ex(leaseOneSql(T,true),[\"worker\",\"worker\"]);\n ok(\"attested_instance_can_lease_recovery\",r.rows?.[0]?.id===\"recover\",{row:r.rows?.[0]});\n\n out.summary={passed:out.tests.filter((x:any)=>x.ok).length,failed:out.failures.length,total:out.tests.length};\n console.log(JSON.stringify(out,null,2));\n}finally{await sqlite.execute(`DROP TABLE IF EXISTS ${T}`)}\nif(out.failures.length)throw new Error(\"TEST_FAILURE:\"+out.failures.join(\",\"));",[],[147,369],"0ebdefd2-7c77-42ef-9f80-3fba5e122e7c","instance_affinity_pure_runner.ts","01a07b80-b4d6-73c0-ae85-237bb89a3e96",["D",1788791971867],"import legacyHealth from \"./legacy_active_health_test.ts\";\nimport heartbeatScope from \"./heartbeat_scope_test.ts\";\n\nconst results:any[]=[];\nfor(const [name,fn] of [[\"legacy_active_health_test\",legacyHealth],[\"heartbeat_scope_test\",heartbeatScope]] as const){\n try{\n const r=fn();\n results.push({name,ok:true,result:r});\n }catch(e){\n results.push({name,ok:false,error:String(e)});\n }\n}\nconsole.log(JSON.stringify(results,null,2));\nif(results.some(x=>!x.ok))throw new Error(\"PURE_REGRESSION_FAILURE\");",[],[147,376],"160dacf0-38f2-4fc3-ad4b-69071a382178","instance_affinity_gap_test.ts","01a07b80-b4d6-73c0-ae85-245d93259a4c",["D",1788791971867],"import { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\nimport { healthHttpStatus, resultSql } from \"./brain_bridge_worker.ts\";\n\nconst JOBS=\"instance_affinity_gap_jobs_z7p3\";\nconst WORKERS=\"instance_affinity_gap_workers_z7p3\";\nconst out:any={tests:[],failures:[]};\nconst ok=(name:string,cond:boolean,detail:any={})=>{out.tests.push({name,ok:!!cond,detail});if(!cond)out.failures.push(name)};\n\nawait sqlite.execute(`DROP TABLE IF EXISTS ${JOBS}`);\nawait sqlite.execute(`DROP TABLE IF EXISTS ${WORKERS}`);\nawait sqlite.execute(`CREATE TABLE ${JOBS}(\n id TEXT PRIMARY KEY, priority REAL NOT NULL DEFAULT 0, op TEXT NOT NULL, payload_json TEXT NOT NULL,\n state TEXT NOT NULL DEFAULT 'READY', lease_owner TEXT, lease_expires_at TEXT, result_json TEXT,error_json TEXT,\n created_at TEXT NOT NULL, updated_at TEXT NOT NULL\n)`);\nawait sqlite.execute(`CREATE TABLE ${WORKERS}(\n endpoint_host TEXT NOT NULL, worker_id TEXT NOT NULL, instance_id TEXT NOT NULL,\n last_poll_at TEXT,last_result_at TEXT,lease_count INTEGER NOT NULL DEFAULT 0,result_count INTEGER NOT NULL DEFAULT 0,\n PRIMARY KEY(endpoint_host,worker_id,instance_id)\n)`);\ntry{\n const worker=\"project-brain-live-v1-worker-v2\";\n await sqlite.execute({sql:`INSERT INTO ${WORKERS} VALUES\n ('main.example',?,'LEGACY_UNATTESTED_INSTANCE',datetime('now','-100 seconds'),datetime('now','-100 seconds'),1,0),\n ('main.example',?,'attested-new',datetime('now'),NULL,0,0)`,args:[worker,worker]});\n await sqlite.execute({sql:`INSERT INTO ${JOBS}\n (id,priority,op,payload_json,state,lease_owner,lease_expires_at,created_at,updated_at)\n VALUES('legacy-origin',1,'brain','{\"args\":[\"verify-chain\"],\"timeout\":60}','LEASED',?,datetime('now','+80 seconds'),datetime('now','-100 seconds'),datetime('now','-100 seconds'))`,args:[worker]});\n\n const latest:any=await sqlite.execute({sql:`SELECT instance_id FROM ${WORKERS}\n WHERE endpoint_host='main.example' AND worker_id=? ORDER BY last_poll_at DESC LIMIT 1`,args:[worker]});\n const recent:any=await sqlite.execute({sql:`SELECT COUNT(*) AS n FROM ${WORKERS}\n WHERE endpoint_host='main.example' AND worker_id=? AND last_poll_at>=datetime('now','-90 seconds')`,args:[worker]});\n const leased:any=await sqlite.execute(`SELECT COUNT(*) AS n FROM ${JOBS} WHERE state='LEASED' AND lease_expires_at>datetime('now')`);\n const selected=String(latest.rows?.[0]?.instance_id||\"\");\n const recentCount=Number(recent.rows?.[0]?.n||0);\n const leasedCount=Number(leased.rows?.[0]?.n||0);\n const currentLegacyActive=(selected===\"LEGACY_UNATTESTED_INSTANCE\")?leasedCount:0;\n const currentStatus=healthHttpStatus(\"HEALTHY\",0,0,currentLegacyActive,recentCount);\n ok(\"pre_repair_legacy_origin_false_green_reproduced\",currentStatus===200,{\n selected,recentCount,leasedCount,currentLegacyActive,currentStatus,\n explanation:\"legacy heartbeat is older than STALE_SECONDS but its 180s lease is still live\"\n });\n\n // Current result predicate has no instance identity. A different instance sharing the logical worker id\n // can complete the live lease. This is recorded as a bounded affinity counterexample, not yet a required\n // production repair in this test.\n const cross:any=await sqlite.execute({sql:resultSql(JOBS),args:[\n \"COMPLETE\",JSON.stringify({from_instance:\"attested-new\"}),null,\"legacy-origin\",worker\n ]});\n const crossAccepted=(cross.rows?.length||0)===1;\n ok(\"result_path_logical_worker_only_cross_instance_acceptance_reproduced\",crossAccepted,{crossAccepted,rows:cross.rows});\n\n out.summary={passed:out.tests.filter((x:any)=>x.ok).length,failed:out.failures.length,total:out.tests.length};\n console.log(JSON.stringify(out,null,2));\n}finally{\n await sqlite.execute(`DROP TABLE IF EXISTS ${JOBS}`);\n await sqlite.execute(`DROP TABLE IF EXISTS ${WORKERS}`);\n}\nif(out.failures.length)throw new Error(\"COUNTEREXAMPLE_REPRODUCTION_FAILURE:\"+out.failures.join(\",\"));",[],[147,383],"7eef4b88-b574-4204-987d-ada070604ffc","inspect_bridge_snapshot_http.ts","01a07b80-b4d6-73c0-ae85-2fa93d499311",["D",1788791971867],"import { blob } from \"https://esm.town/v/std/blob/main.ts\";\nexport default async function(req:Request){\n const u=new URL(req.url);\n const q=(u.searchParams.get(\"q\")||\"\").toLowerCase();\n const key=\"snapshots/brain_snapshot_g1235_08f571acc715207e.json\";\n const d=JSON.parse(await (await blob.get(key)).text());\n const hit=(x:any)=>JSON.stringify(x).toLowerCase().includes(q);\n const tasks=(d?.snapshot?.tasks||[]).filter(hit).map((x:any)=>({\n id:x.id,workstream:x.workstream,state:x.state,priority:x.priority,dedupe_key:x.dedupe_key,\n result_event_id:x.result_event_id,context_manifest:x.context_manifest,requires_json:x.requires_json,writes_json:x.writes_json\n }));\n const arts=(d?.artifacts||[]).filter(hit).map((x:any)=>({\n logical_name:x.logical_name,sha256:x.sha256,size:x.size,storage_json:x.storage_json,task_id:x.task_id,producer_agent:x.producer_agent\n }));\n const events=(d?.events||[]).filter(hit).slice(-30).map((x:any)=>({\n id:x.id,ts:x.ts,type:x.type,workstream:x.workstream,task_id:x.task_id,payload:JSON.parse(x.payload_json)\n }));\n return Response.json({q,generation:d?.snapshot?.generation,tasks,artifacts:arts,events});\n}",[],[147,390],"70f69d06-4b29-43e2-9709-7634c90bbcec","inspect_bridge_snapshot.ts","01a07b80-b4d6-73c0-ae85-2973b6f78877",["D",1788791971867],"import { blob } from \"https://esm.town/v/std/blob/main.ts\";\n\nexport default async function() {\n const key=\"snapshots/brain_snapshot_g1235_08f571acc715207e.json\";\n const raw=await (await blob.get(key)).text();\n const d=JSON.parse(raw);\n const s=(x:any)=>JSON.stringify(x).toLowerCase();\n const hit=(x:any)=>[\"bridge\",\"worker-v2\",\"brain-val\",\"bridge_worker\",\"val-bridge\"].some(k=>s(x).includes(k));\n const tasks=(d?.snapshot?.tasks||[]).filter(hit).map((x:any)=>({\n id:x.id,workstream:x.workstream,state:x.state,dedupe_key:x.dedupe_key,\n context_manifest:x.context_manifest,requires_json:x.requires_json,writes_json:x.writes_json,\n result_event_id:x.result_event_id,lease_owner:x.lease_owner\n }));\n const artifacts=(d?.artifacts||[]).filter(hit).map((x:any)=>({\n sha256:x.sha256,logical_name:x.logical_name,storage_json:x.storage_json,\n producer_agent:x.producer_agent,task_id:x.task_id,size:x.size\n }));\n const recovery=(d?.recovery_files||[]).filter(hit).map((x:any)=>({\n logical_path:x.logical_path,sha256:x.sha256,size:x.size,\n excerpt:(x.content_utf8||\"\").slice(0,3000)\n }));\n const events=(d?.events||[]).filter(hit).slice(-60).map((x:any)=>({\n id:x.id,ts:x.ts,type:x.type,workstream:x.workstream,agent_id:x.agent_id,task_id:x.task_id,\n payload_json:x.payload_json\n }));\n const out={key,generation:d?.snapshot?.generation,event_head_hash:d?.snapshot?.event_head_hash,\n tasks,artifacts,recovery,events};\n console.log(JSON.stringify(out));\n return {ok:true,counts:{tasks:tasks.length,artifacts:artifacts.length,recovery:recovery.length,events:events.length}};\n}",[],[147,397],"c5a45c4e-e60c-4e46-8faf-752ec1ee50a3","heartbeat_scope_test.ts","01a07b80-b4d6-73c0-ae85-313d48ce25f7",["D",1788791971867],"import { endpointScope, healthHttpStatus } from \"./brain_bridge_worker.ts\";\nfunction assert(c:boolean,m:string){if(!c)throw new Error(m)}\nexport default function(){\n assert(endpointScope(new Request(\"https://MAIN.Example.test/health\"))===\"main.example.test\",\"endpoint host normalization\");\n assert(endpointScope(new Request(\"https://candidate.example.test/poll\"))===\"candidate.example.test\",\"endpoint host isolation\");\n assert(healthHttpStatus(\"HEALTHY\",0,0,0,1)===200,\"one recent expected instance can be healthy\");\n assert(healthHttpStatus(\"HEALTHY\",0,0,0,0)===503,\"zero recent expected instances fails closed\");\n assert(healthHttpStatus(\"HEALTHY\",0,0,0,2)===503,\"two recent expected instances fails closed\");\n assert(healthHttpStatus(\"HEALTHY\",0,0,1,1)===503,\"legacy active lease remains fail closed\");\n return {ok:true,assertions:6,classification:\"ENDPOINT_SCOPED_HEARTBEAT_AND_INSTANCE_CARDINALITY_PASS\"};\n}",[],[147,404],"094c7962-d88d-4bed-a800-e71abf53e03f","heartbeat_scope_integration.ts","01a07b80-b4d6-73c0-ae85-360d508fb1c1",["D",1788791971867],"import { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\nimport { healthHttpStatus } from \"./brain_bridge_worker.ts\";\nconst T=\"heartbeat_scope_integration_0144\";\nconst out:any={tests:[],failures:[]};\nconst ok=(name:string,cond:boolean,detail:any={})=>{out.tests.push({name,ok:!!cond,detail});if(!cond)out.failures.push(name)};\nawait sqlite.execute(`DROP TABLE IF EXISTS ${T}`);\nawait sqlite.execute(`CREATE TABLE ${T}(\n endpoint_host TEXT NOT NULL,worker_id TEXT NOT NULL,instance_id TEXT NOT NULL,\n last_poll_at TEXT,last_result_at TEXT,lease_count INTEGER NOT NULL DEFAULT 0,\n result_count INTEGER NOT NULL DEFAULT 0,PRIMARY KEY(endpoint_host,worker_id,instance_id)\n)`);\ntry{\n await sqlite.execute(`INSERT INTO ${T} VALUES\n ('main.example','project-brain-live-v1-worker-v2','LEGACY_UNATTESTED_INSTANCE',datetime('now','-1 second'),datetime('now','-1 second'),110,106),\n ('main.example','project-brain-live-v1-worker-v2','c7d7f290-2f43-4fda-a997-e2133962ac83',datetime('now','-2 seconds'),datetime('now','-190 seconds'),12,11),\n ('main.example','project-brain-live-v1-worker-v2','70d03cb9-a66b-4bfd-8186-070849e9fc09',datetime('now','-3 seconds'),NULL,0,0),\n ('candidate.example','project-brain-live-v1-worker-v2','candidate-only',datetime('now'),datetime('now'),1,1)`);\n const main:any=await sqlite.execute(`SELECT COUNT(*) AS n FROM ${T}\n WHERE endpoint_host='main.example' AND worker_id='project-brain-live-v1-worker-v2'\n AND last_poll_at>=datetime('now','-90 seconds')`);\n const candidate:any=await sqlite.execute(`SELECT COUNT(*) AS n FROM ${T}\n WHERE endpoint_host='candidate.example' AND worker_id='project-brain-live-v1-worker-v2'\n AND last_poll_at>=datetime('now','-90 seconds')`);\n ok(\"three_recent_main_instances_detected\",Number(main.rows?.[0]?.n)===3,{row:main.rows?.[0]});\n ok(\"candidate_endpoint_isolated\",Number(candidate.rows?.[0]?.n)===1,{row:candidate.rows?.[0]});\n ok(\"main_three_instances_health_503\",healthHttpStatus(\"HEALTHY\",0,0,0,Number(main.rows?.[0]?.n))===503);\n ok(\"candidate_single_instance_can_be_200\",healthHttpStatus(\"HEALTHY\",0,0,0,Number(candidate.rows?.[0]?.n))===200);\n out.summary={passed:out.tests.filter((x:any)=>x.ok).length,failed:out.failures.length,total:out.tests.length};\n console.log(JSON.stringify(out,null,2));\n}finally{await sqlite.execute(`DROP TABLE IF EXISTS ${T}`)}\nif(out.failures.length)throw new Error(\"TEST_FAILURE:\"+out.failures.join(\",\"));",[],[147,411],"53cd8649-f1d5-4b99-a0dd-2e97bdc5c66c","hash_evidence_z7p3.ts","01a07b80-b4d6-73c0-ae85-3b9f626524f3",["D",1788791971867],"const docs={\"live\":\"{\\n \\\"schema\\\": \\\"PROJECT_BRAIN_INSTANCE_AFFINITY_LIVE_FALSE_GREEN_V1\\\",\\n \\\"observed_at_utc\\\": \\\"2026-09-06T00:26:54Z\\\",\\n \\\"classification\\\": \\\"VERIFIED_TRANSPORT_OBSERVATION_NONAUTHORITY\\\",\\n \\\"endpoint_host\\\": \\\"mosadek--f6c41144a97511f1a66b1607ee4eb77e.web.val.run\\\",\\n \\\"expected_worker_id\\\": \\\"project-brain-live-v1-worker-v2\\\",\\n \\\"recent_instance_window_seconds\\\": 90,\\n \\\"recent_attested_instances\\\": [\\n {\\n \\\"instance_id\\\": \\\"eedd0655-d128-4f32-9f73-94e2c5963c88\\\",\\n \\\"first_seen_at\\\": \\\"2026-09-06 00:25:13\\\",\\n \\\"last_poll_at\\\": \\\"2026-09-06 00:26:12\\\",\\n \\\"last_result_at\\\": null,\\n \\\"lease_count\\\": 0,\\n \\\"result_count\\\": 0\\n },\\n {\\n \\\"instance_id\\\": \\\"0651b693-4d0b-4c12-ade4-d0f183fafe9e\\\",\\n \\\"first_seen_at\\\": \\\"2026-09-06 00:20:06\\\",\\n \\\"last_poll_at\\\": \\\"2026-09-06 00:24:57\\\",\\n \\\"last_result_at\\\": \\\"2026-09-06 00:24:46\\\",\\n \\\"lease_count\\\": 30,\\n \\\"result_count\\\": 29\\n }\\n ],\\n \\\"production_health\\\": {\\n \\\"http_status\\\": 200,\\n \\\"selected_instance_id\\\": \\\"eedd0655-d128-4f32-9f73-94e2c5963c88\\\",\\n \\\"selected_last_poll_at\\\": \\\"2026-09-06 00:26:12\\\",\\n \\\"selected_poll_age_seconds\\\": 42,\\n \\\"worker_state\\\": \\\"HEALTHY\\\",\\n \\\"duplicate_active_worker_leases\\\": 0,\\n \\\"ready_count\\\": 27,\\n \\\"leased_count\\\": 1,\\n \\\"expired_lease_count\\\": 0,\\n \\\"earliest_lease_expiry\\\": \\\"2026-09-06 00:27:58\\\"\\n },\\n \\\"counterexample\\\": \\\"Production health returned 200 while two attested instances of the same logical worker were within the 90-second recent window.\\\",\\n \\\"production_main_mutated\\\": false,\\n \\\"canonical_brain_mutated\\\": false,\\n \\\"direct_sprites_used_for_this_observation\\\": false\\n}\",\"receipt\":\"{\\n \\\"schema\\\": \\\"PROJECT_BRAIN_INSTANCE_AFFINITY_CANDIDATE_RECEIPT_V2\\\",\\n \\\"classification\\\": \\\"CANDIDATE_NONAUTHORITY_NOT_PROMOTED\\\",\\n \\\"task_id\\\": \\\"BRAIN-VAL-BRIDGE-WORKER-INSTANCE-AFFINITY-V1-20260906\\\",\\n \\\"agent_id\\\": \\\"chat-global-bbn-20260906-0210-sol-z7p3\\\",\\n \\\"branch\\\": \\\"instance-affinity-z7p3\\\",\\n \\\"source_branch\\\": \\\"recovery-first-sol-0120\\\",\\n \\\"candidate_files\\\": [\\n {\\n \\\"path\\\": \\\"brain_bridge_worker.ts\\\",\\n \\\"bytes\\\": 16194,\\n \\\"sha256\\\": \\\"90282f86e96161aa5008a623e76702fc596d18174d1065799b50d1707f981094\\\"\\n },\\n {\\n \\\"path\\\": \\\"legacy_lease_horizon_test.ts\\\",\\n \\\"bytes\\\": 2835,\\n \\\"sha256\\\": \\\"676e9fb0bc6c998aae5d9c88bd2a4c816cbff2ad44c477a473e9ddd2e43585e1\\\"\\n },\\n {\\n \\\"path\\\": \\\"instance_affinity_gap_test.ts\\\",\\n \\\"bytes\\\": 3893,\\n \\\"sha256\\\": \\\"a335ca6a1fb7395d32793ece2dc73e3ea6623705d2dc5629aa15c94d67538b3b\\\"\\n },\\n {\\n \\\"path\\\": \\\"instance_affinity_pure_runner.ts\\\",\\n \\\"bytes\\\": 511,\\n \\\"sha256\\\": \\\"5b02db492422ff7d604a676896dc789cc9b5df58f355d4a18dc9b06c12900de1\\\"\\n }\\n ],\\n \\\"repaired_properties\\\": [\\n \\\"endpoint-host scoped heartbeat state\\\",\\n \\\"health bound to expected worker id\\\",\\n \\\"zero/multiple recent expected-worker instances fail closed\\\",\\n \\\"legacy-unattested active-lease risk held closed for full 180-second lease horizon\\\",\\n \\\"legacy executors skip recover-stale but may take ordinary jobs\\\",\\n \\\"attested executors may take recover-stale\\\",\\n \\\"same logical worker single-flight preserved\\\"\\n ],\\n \\\"tests\\\": {\\n \\\"recovery_first\\\": \\\"4/4 PASS\\\",\\n \\\"instance_affinity\\\": \\\"5/5 PASS\\\",\\n \\\"heartbeat_scope_integration\\\": \\\"4/4 PASS\\\",\\n \\\"legacy_lease_horizon\\\": \\\"5/5 PASS\\\",\\n \\\"pure_health_and_scope\\\": \\\"12/12 PASS\\\",\\n \\\"inherited_v5_regression\\\": \\\"49/49 PASS\\\",\\n \\\"inherited_v3_stress\\\": \\\"6/6 PASS\\\",\\n \\\"executed_candidate_assertions_total\\\": 85,\\n \\\"counterexample_reproductions\\\": \\\"2/2 PASS\\\",\\n \\\"branch_health_without_scoped_poll\\\": \\\"HTTP 503 UNKNOWN\\\"\\n },\\n \\\"evidence\\\": [\\n \\\"valblob:mosadek/project-brain-live-v1-durable/diagnostics/brain_bridge/supervision_v2/heartbeat_scope_contamination_counterexample.json\\\",\\n \\\"valblob:mosadek/project-brain-live-v1-durable/diagnostics/brain_bridge/supervision_v2/recovery_scope_candidate_receipt.json\\\",\\n \\\"valblob:mosadek/project-brain-live-v1-durable/diagnostics/brain_bridge/instance_affinity_z7p3/live_false_green_v1.json\\\"\\n ],\\n \\\"residual_defect\\\": {\\n \\\"classification\\\": \\\"EXACT_RESULT_INSTANCE_FENCING_NOT_SOLVED_BY_THIS_CANDIDATE\\\",\\n \\\"reproduced\\\": true,\\n \\\"description\\\": \\\"A different executor instance sharing the logical worker id can complete the live lease under current resultSql.\\\",\\n \\\"existing_design_task\\\": \\\"BITS-VAL-BRIDGE-LEASE-INCARNATION-ABA-REPAIR-DESIGN-20260906\\\",\\n \\\"existing_design_branch\\\": \\\"bridge-lease-incarnation-aba-c7a1\\\",\\n \\\"required_composition\\\": \\\"lease_token + lease_instance_id exact result predicate before broader exact-incarnation claim\\\"\\n },\\n \\\"promotion\\\": false,\\n \\\"production_main_mutated\\\": false,\\n \\\"canonical_brain_py_mutated\\\": false,\\n \\\"direct_sprites_calls_during_claimed_task\\\": 0,\\n \\\"preclaim_maintenance_note\\\": \\\"Two read-only service_get checks occurred before task claim under the explicit maintenance-emergency exception; both observed self-restart and made no host mutation.\\\",\\n \\\"human_authority_approval\\\": false\\n}\"};\nconst enc=new TextEncoder();\nconst hex=(b:Uint8Array)=>[...b].map(x=>x.toString(16).padStart(2,\"0\")).join(\"\");\nconst out:any={};\nfor(const [k,s] of Object.entries(docs)){\n const bytes=enc.encode(s as string);\n const digest=new Uint8Array(await crypto.subtle.digest(\"SHA-256\",bytes));\n out[k]={bytes:bytes.length,sha256:hex(digest)};\n}\nconsole.log(JSON.stringify(out,null,2));",[],[147,418],"2cb4fbcc-d1f7-4a29-aafb-f2510010cd0d","hash_branch_artifacts.ts","01a07b80-b4d6-73c0-ae85-3ffa216e5437",["D",1788791971867],"const files={\"brain_bridge_worker.ts\":\"import { sqlite } from \\\"https://esm.town/v/std/sqlite/main.ts\\\";\\n\\nconst WORKER_TOKEN = Deno.env.get(\\\"BRAIN_BRIDGE_WORKER_TOKEN\\\") || \\\"\\\";\\nconst JOB_TABLE = \\\"brain_bridge_jobs\\\";\\nconst WORKER_TABLE = \\\"brain_bridge_workers_v6\\\";\\nconst EXPECTED_WORKER_ID = \\\"project-brain-live-v1-worker-v2\\\";\\nexport const STALE_SECONDS = 90;\\nexport const DEAD_SECONDS = 180;\\nexport const PRIORITY_CAP = 1_000_000_000;\\nexport const MAX_JOB_TIMEOUT = 120;\\nexport const LEASE_SECONDS = 180;\\nexport const MAX_READ_BYTES = 200_000;\\n\\nexport const SUPPORTED_BRAIN_COMMANDS = [\\n \\\"status\\\",\\n \\\"verify-chain\\\",\\n \\\"verify-claim-graph\\\",\\n \\\"register-agent\\\",\\n \\\"ensure-task\\\",\\n \\\"delegate-task\\\",\\n \\\"claim\\\",\\n \\\"renew-lease\\\",\\n \\\"commit\\\",\\n \\\"checkpoint\\\",\\n \\\"add-claim\\\",\\n \\\"invalidate-claim\\\",\\n \\\"supersede-task-context\\\",\\n \\\"migrate-task-invariants\\\",\\n \\\"reconcile-causal-blocks\\\",\\n \\\"recover-stale\\\"\\n] as const;\\nconst SUPPORTED = new Set(SUPPORTED_BRAIN_COMMANDS);\\n\\nfunction json(v:unknown,status=200){return Response.json(v,{status});}\\nfunction tableName(table:string){if(!/^[A-Za-z_][A-Za-z0-9_]*$/.test(table))throw new Error(\\\"BAD_TABLE\\\");return table;}\\n\\nexport function classifyWorkerAge(ageSeconds:number|null){\\n if(ageSeconds===null || !Number.isFinite(ageSeconds)) return {state:\\\"UNKNOWN\\\",reason:\\\"NO_WORKER_HEARTBEAT\\\"};\\n if(ageSeconds<=STALE_SECONDS) return {state:\\\"HEALTHY\\\",reason:\\\"RECENT_WORKER_POLL\\\"};\\n if(ageSeconds<=DEAD_SECONDS) return {state:\\\"DEGRADED\\\",reason:\\\"WORKER_POLL_STALE\\\"};\\n return {state:\\\"DOWN\\\",reason:\\\"WORKER_POLL_DEAD\\\"};\\n}\\nexport function effectivePriority(x:number){if(!Number.isFinite(x))return 0;return Math.min(x,PRIORITY_CAP);}\\nexport function healthHttpStatus(workerState:string,duplicateActiveLeases:number,expiredLeases:number,legacyUnattestedActiveLeases=0,recentInstanceCount=1){\\n return workerState===\\\"HEALTHY\\\" && duplicateActiveLeases===0 && expiredLeases===0 && legacyUnattestedActiveLeases===0 && recentInstanceCount===1 ? 200 : 503;\\n}\\nexport function legacyLeaseRiskLeases(leasedCount:number,legacyRiskCount:number){\\n return legacyRiskCount>0 && leasedCount>0 ? leasedCount : 0;\\n}\\nexport function activeLeaseDecision(rows:any[]){\\n if(rows.length>1)return {kind:\\\"conflict\\\" as const,count:rows.length};\\n if(rows[0])return {kind:\\\"busy\\\" as const,active_job_id:String(rows[0].id),lease_expires_at:rows[0].lease_expires_at};\\n return {kind:\\\"free\\\" as const};\\n}\\n\\nexport function recoverExpiredSql(table=JOB_TABLE){\\n table=tableName(table);\\n return `UPDATE ${table}\\n SET state='READY',lease_owner=NULL,lease_expires_at=NULL,updated_at=datetime('now')\\n WHERE state='LEASED' AND lease_expires_at IS NOT NULL AND lease_expires_at <= datetime('now')`;\\n}\\nexport function activeLeaseSql(table=JOB_TABLE){\\n table=tableName(table);\\n return `SELECT id,op,payload_json,priority,lease_expires_at\\n FROM ${table}\\n WHERE state='LEASED' AND lease_owner=? AND lease_expires_at > datetime('now')\\n ORDER BY lease_expires_at,id LIMIT 2`;\\n}\\nexport function isAttestedInstance(instance:string){return !!instance && instance!==\\\"LEGACY_UNATTESTED_INSTANCE\\\";}\\nfunction exactRecoverPredicate(alias=\\\"j\\\"){\\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]')='recover-stale'\\n AND json_type(${alias}.payload_json,'$.timeout')='integer'\\n AND json_extract(${alias}.payload_json,'$.timeout') BETWEEN 1 AND ${MAX_JOB_TIMEOUT}\\n AND (SELECT COUNT(*) FROM json_each(${alias}.payload_json))=2)`;\\n}\\nexport function leaseOneSql(table=JOB_TABLE,allowRecovery=true){\\n table=tableName(table);\\n const recover=exactRecoverPredicate(\\\"j\\\");\\n const recoveryEligibility=allowRecovery ? \\\"1=1\\\" : `NOT ${recover}`;\\n const recoveryOrder=allowRecovery ? `CASE WHEN ${recover} THEN 0 ELSE 1 END` : \\\"1\\\";\\n return `UPDATE ${table}\\n SET state='LEASED',lease_owner=?,lease_expires_at=datetime('now','+${LEASE_SECONDS} seconds'),updated_at=datetime('now')\\n WHERE id=(\\n SELECT j.id FROM ${table} j\\n WHERE j.state='READY'\\n AND (${recoveryEligibility})\\n AND NOT EXISTS(\\n SELECT 1 FROM ${table} x\\n WHERE x.state='LEASED' AND x.lease_owner=? AND x.lease_expires_at > datetime('now')\\n )\\n ORDER BY\\n ${recoveryOrder} ASC,\\n CASE WHEN j.priority > ${PRIORITY_CAP} THEN ${PRIORITY_CAP} 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`;\\n}\\nexport function resultSql(table=JOB_TABLE){\\n table=tableName(table);\\n return `UPDATE ${table}\\n SET state=?,result_json=?,error_json=?,lease_expires_at=NULL,updated_at=datetime('now')\\n WHERE id=? AND state='LEASED' AND lease_owner=? AND lease_expires_at > datetime('now')\\n RETURNING id,state`;\\n}\\n\\nexport type DispatchResult=\\n | {ok:true;payload_json:string}\\n | {ok:false;error:string};\\n\\nfunction exactKeys(q:any, expected:string[]){\\n const got=Object.keys(q).sort();\\n const want=[...expected].sort();\\n return got.length===want.length && got.every((k,i)=>k===want[i]);\\n}\\n\\nexport function normalizeDispatch(op:string,payloadJson:string):DispatchResult{\\n let q:any;try{q=JSON.parse(payloadJson)}catch{return {ok:false,error:\\\"PAYLOAD_JSON_INVALID\\\"}}\\n if(!q || typeof q!==\\\"object\\\" || Array.isArray(q))return {ok:false,error:\\\"PAYLOAD_OBJECT_REQUIRED\\\"};\\n\\n if(op===\\\"brain\\\"){\\n if(!exactKeys(q,[\\\"args\\\",\\\"timeout\\\"]))return {ok:false,error:\\\"BRAIN_PAYLOAD_SCHEMA_NOT_CLOSED\\\"};\\n if(!Array.isArray(q.args) || q.args.length<1 || q.args.some((x:any)=>typeof x!==\\\"string\\\"))return {ok:false,error:\\\"BRAIN_ARGS_INVALID\\\"};\\n if(!Number.isInteger(q.timeout) || q.timeout<1 || q.timeout>MAX_JOB_TIMEOUT)return {ok:false,error:\\\"BRAIN_TIMEOUT_INVALID\\\"};\\n const cmd=q.args[0];\\n if(cmd===\\\"boot\\\")return {ok:false,error:\\\"BOOT_NOT_ATOMIC_USE_REGISTER_AGENT_THEN_CLAIM\\\"};\\n if(cmd===\\\"boot-agent\\\")return {ok:false,error:\\\"RAW_BOOT_AGENT_NOT_BRIDGE_COMMAND\\\"};\\n if(cmd===\\\"recover-leases\\\")return {ok:false,error:\\\"RECOVER_LEASE_ALIAS_NOT_AVAILABLE_ON_CURRENT_EXECUTOR\\\"};\\n if(!SUPPORTED.has(cmd))return {ok:false,error:\\\"BRAIN_SUBCOMMAND_NOT_ALLOWED\\\"};\\n return {ok:true,payload_json:JSON.stringify({args:q.args,timeout:q.timeout})};\\n }\\n\\n if(op===\\\"read_text\\\"){\\n if(!exactKeys(q,[\\\"path\\\",\\\"max_bytes\\\"]))return {ok:false,error:\\\"READ_TEXT_SCHEMA_NOT_CLOSED\\\"};\\n if(typeof q.path!==\\\"string\\\")return {ok:false,error:\\\"READ_TEXT_PATH_REQUIRED\\\"};\\n if(q.path.includes(\\\"\\\\0\\\") || q.path.includes(\\\"\\\\\\\\\\\") || q.path.split(\\\"/\\\").some((s:string)=>s===\\\".\\\" || s===\\\"..\\\")){\\n return {ok:false,error:\\\"READ_TEXT_TRAVERSAL_REJECTED\\\"};\\n }\\n const artifactFile=q.path.startsWith(\\\"/brain/artifacts/\\\") && q.path.length>\\\"/brain/artifacts/\\\".length && !q.path.endsWith(\\\"/\\\");\\n if(!(q.path===\\\"/brain/JOIN_PROTOCOL.md\\\" || artifactFile))return {ok:false,error:\\\"READ_TEXT_PATH_FORBIDDEN\\\"};\\n if(!Number.isInteger(q.max_bytes) || q.max_bytes<1 || q.max_bytes>MAX_READ_BYTES)return {ok:false,error:\\\"READ_TEXT_MAX_BYTES_INVALID\\\"};\\n return {ok:true,payload_json:JSON.stringify({path:q.path,max_bytes:q.max_bytes})};\\n }\\n return {ok:false,error:\\\"OP_UNSUPPORTED\\\"};\\n}\\n\\nasync function ensureTables(){\\n await sqlite.execute(`CREATE TABLE IF NOT EXISTS ${WORKER_TABLE} (\\n endpoint_host TEXT NOT NULL,\\n worker_id TEXT NOT NULL,\\n instance_id TEXT NOT NULL,\\n first_seen_at TEXT NOT NULL,\\n last_poll_at TEXT,\\n last_result_at TEXT,\\n lease_count INTEGER NOT NULL DEFAULT 0,\\n result_count INTEGER NOT NULL DEFAULT 0,\\n updated_at TEXT NOT NULL,\\n PRIMARY KEY(endpoint_host,worker_id,instance_id)\\n )`);\\n}\\nfunction instanceOf(q:any){const v=String(q?.instance_id||\\\"\\\").trim();return v||\\\"LEGACY_UNATTESTED_INSTANCE\\\";}\\nexport function endpointScope(req:Request){return new URL(req.url).host.toLowerCase();}\\n\\nasync function workerHealth(endpointHost:string){\\n await ensureTables();\\n const wr:any=await sqlite.execute({\\n sql:`SELECT worker_id,instance_id,last_poll_at,last_result_at,lease_count,result_count,\\n CAST((julianday('now')-julianday(last_poll_at))*86400 AS INTEGER) AS poll_age_seconds\\n FROM ${WORKER_TABLE}\\n WHERE endpoint_host=? AND worker_id=?\\n ORDER BY last_poll_at DESC LIMIT 1`,\\n args:[endpointHost,EXPECTED_WORKER_ID]\\n });\\n const w=wr.rows?.[0]||null;\\n const ri:any=await sqlite.execute({\\n sql:`SELECT COUNT(*) AS recent_instance_count\\n FROM ${WORKER_TABLE}\\n WHERE endpoint_host=? AND worker_id=?\\n AND last_poll_at IS NOT NULL\\n AND last_poll_at >= datetime('now', '-' || ? || ' seconds')`,\\n args:[endpointHost,EXPECTED_WORKER_ID,STALE_SECONDS]\\n });\\n const recentInstanceCount=Number(ri.rows?.[0]?.recent_instance_count||0);\\n const legacyRisk:any=await sqlite.execute({\\n sql:`SELECT COUNT(*) AS legacy_risk_count\\n FROM ${WORKER_TABLE}\\n WHERE endpoint_host=? AND worker_id=?\\n AND instance_id='LEGACY_UNATTESTED_INSTANCE'\\n AND last_poll_at IS NOT NULL\\n AND last_poll_at >= datetime('now', '-' || ? || ' seconds')`,\\n args:[endpointHost,EXPECTED_WORKER_ID,LEASE_SECONDS]\\n });\\n const legacyRiskCount=Number(legacyRisk.rows?.[0]?.legacy_risk_count||0);\\n const qc:any=await sqlite.execute({\\n sql:`SELECT\\n SUM(CASE WHEN state='READY' THEN 1 ELSE 0 END) AS ready_count,\\n SUM(CASE WHEN state='LEASED' THEN 1 ELSE 0 END) AS leased_count,\\n SUM(CASE WHEN state='LEASED' AND lease_expires_at <= datetime('now') THEN 1 ELSE 0 END) AS expired_lease_count,\\n SUM(CASE WHEN state='READY' AND priority > ? THEN 1 ELSE 0 END) AS overcap_ready_count,\\n MIN(CASE WHEN state='READY' THEN created_at END) AS oldest_ready_at,\\n MIN(CASE WHEN state='LEASED' THEN lease_expires_at END) AS earliest_lease_expiry\\n FROM brain_bridge_jobs`,\\n args:[PRIORITY_CAP]\\n });\\n const dup:any=await sqlite.execute(`\\n SELECT COUNT(*) AS duplicate_worker_count FROM (\\n SELECT lease_owner FROM brain_bridge_jobs\\n WHERE state='LEASED' AND lease_expires_at > datetime('now') AND lease_owner IS NOT NULL\\n GROUP BY lease_owner HAVING COUNT(*) > 1\\n )`);\\n const q=qc.rows?.[0]||{};\\n const duplicateActiveLeases=Number(dup.rows?.[0]?.duplicate_worker_count||0);\\n const cls=classifyWorkerAge(w?Number(w.poll_age_seconds):null);\\n const expiredLeases=Number(q.expired_lease_count||0);\\n const leasedCount=Number(q.leased_count||0);\\n // A legacy process can own a still-live 180s queue lease after its heartbeat has aged\\n // beyond the 90s recent-instance window. Conservatively hold health closed for the\\n // full lease horizon whenever any legacy heartbeat in this endpoint scope could still\\n // be the origin of an active lease.\\n const legacyUnattestedActiveLeases=legacyLeaseRiskLeases(leasedCount,legacyRiskCount);\\n const status=healthHttpStatus(cls.state,duplicateActiveLeases,expiredLeases,legacyUnattestedActiveLeases,recentInstanceCount);\\n return {status,body:{\\n endpoint_ok:true,\\n service:\\\"brain-bridge-worker-v5-rebased-candidate\\\",\\n worker:w,\\n worker_state:cls.state,\\n worker_reason:cls.reason,\\n instance_identity_available:w ? w.instance_id!==\\\"LEGACY_UNATTESTED_INSTANCE\\\" : false,\\n duplicate_active_worker_leases:duplicateActiveLeases,\\n legacy_unattested_active_leases:legacyUnattestedActiveLeases,\\n expected_worker_id:EXPECTED_WORKER_ID,\\n recent_expected_worker_instances:recentInstanceCount,\\n queue:q,\\n transport_priority_cap:PRIORITY_CAP,\\n max_brain_timeout_seconds:MAX_JOB_TIMEOUT,\\n queue_lease_seconds:LEASE_SECONDS,\\n selection_policy:\\\"RECOVERY_FIRST_THEN_CLAMPED_PRIORITY_FIFO_SINGLE_FLIGHT\\\",\\n atomic_single_flight:true,\\n fail_closed_http_status:status\\n }};\\n}\\n\\nasync function rejectInvalidLease(worker:string,id:string,error:string){\\n await sqlite.execute({\\n sql:`UPDATE ${JOB_TABLE}\\n SET state='FAILED',result_json=NULL,error_json=?,lease_expires_at=NULL,updated_at=datetime('now')\\n WHERE id=? AND state='LEASED' AND lease_owner=?`,\\n args:[JSON.stringify({classification:\\\"BRIDGE_DISPATCH_REJECTED\\\",error}),id,worker]\\n });\\n}\\n\\nexport default async function(req:Request):Promise{\\n const u=new URL(req.url);\\n const endpointHost=endpointScope(req);\\n if(req.method===\\\"GET\\\" && u.pathname.endsWith(\\\"/health\\\")){\\n const h=await workerHealth(endpointHost);return json(h.body,h.status);\\n }\\n if(req.method!==\\\"POST\\\")return json({ok:false,error:\\\"METHOD\\\"},405);\\n const supplied=req.headers.get(\\\"x-brain-worker-token\\\")||\\\"\\\";\\n if(!WORKER_TOKEN || supplied!==WORKER_TOKEN)return json({ok:false,error:\\\"UNAUTHORIZED\\\"},401);\\n let q:any;try{q=await req.json()}catch{return json({ok:false,error:\\\"BAD_JSON\\\"},400)}\\n await ensureTables();\\n\\n if(u.pathname.endsWith(\\\"/poll\\\")){\\n const worker=String(q.worker_id||\\\"\\\").trim();\\n if(!worker || worker.length>128)return json({ok:false,error:\\\"WORKER_REQUIRED\\\"},400);\\n if(worker!==EXPECTED_WORKER_ID)return json({ok:false,error:\\\"WORKER_ID_MISMATCH\\\"},403);\\n const instance=instanceOf(q);\\n await sqlite.execute({\\n sql:`INSERT INTO ${WORKER_TABLE}(endpoint_host,worker_id,instance_id,first_seen_at,last_poll_at,updated_at)\\n VALUES(?,?,?,datetime('now'),datetime('now'),datetime('now'))\\n ON CONFLICT(endpoint_host,worker_id,instance_id) DO UPDATE SET last_poll_at=datetime('now'),updated_at=datetime('now')`,\\n args:[endpointHost,worker,instance]\\n });\\n\\n await sqlite.execute(recoverExpiredSql());\\n const ar:any=await sqlite.execute({sql:activeLeaseSql(),args:[worker]});\\n const before=activeLeaseDecision(ar.rows||[]);\\n if(before.kind===\\\"conflict\\\")return json({ok:false,error:\\\"MULTIPLE_ACTIVE_LEASES\\\",worker_id:worker,count:before.count},409);\\n if(before.kind===\\\"busy\\\")return json({ok:true,job:null,reason:\\\"ACTIVE_LEASE_EXISTS\\\",active_lease:{id:before.active_job_id,lease_expires_at:before.lease_expires_at},worker_id:worker,instance_id:instance});\\n\\n const r:any=await sqlite.execute({sql:leaseOneSql(JOB_TABLE,isAttestedInstance(instance)),args:[worker,worker]});\\n if(!r.rows?.[0]){\\n return json({ok:true,job:null,reason:\\\"NO_READY_JOB_OR_RACED_ACTIVE_LEASE\\\",worker_id:worker,instance_id:instance,priority_cap:PRIORITY_CAP});\\n }\\n\\n const row=r.rows[0];\\n const normalized=normalizeDispatch(String(row.op),String(row.payload_json));\\n if(!normalized.ok){\\n await rejectInvalidLease(worker,String(row.id),normalized.error);\\n return json({ok:true,job:null,reason:\\\"DISPATCH_REJECTED\\\",rejected_job:String(row.id),dispatch_error:normalized.error,worker_id:worker,instance_id:instance});\\n }\\n\\n await sqlite.execute({\\n sql:`UPDATE ${WORKER_TABLE} SET lease_count=lease_count+1,updated_at=datetime('now') WHERE endpoint_host=? AND worker_id=? AND instance_id=?`,\\n args:[endpointHost,worker,instance]\\n });\\n return json({ok:true,job:{...row,payload_json:normalized.payload_json},worker_id:worker,instance_id:instance,priority_cap:PRIORITY_CAP,lease_seconds:LEASE_SECONDS});\\n }\\n\\n if(u.pathname.endsWith(\\\"/result\\\")){\\n const worker=String(q.worker_id||\\\"\\\").trim(),id=String(q.id||\\\"\\\").trim(),success=q.success===true;\\n const instance=instanceOf(q);\\n if(!worker||!id)return json({ok:false,error:\\\"BAD_RESULT_ID\\\"},400);\\n if(worker!==EXPECTED_WORKER_ID)return json({ok:false,error:\\\"WORKER_ID_MISMATCH\\\"},403);\\n const r:any=await sqlite.execute({\\n sql:resultSql(),\\n args:[success?\\\"COMPLETE\\\":\\\"FAILED\\\",success?JSON.stringify(q.result??null):null,success?null:JSON.stringify(q.error??null),id,worker]\\n });\\n if(!r.rows?.length)return json({ok:false,error:\\\"LEASE_MISMATCH_OR_EXPIRED\\\"},409);\\n await sqlite.execute({\\n sql:`UPDATE ${WORKER_TABLE} SET last_result_at=datetime('now'),result_count=result_count+1,updated_at=datetime('now') WHERE endpoint_host=? AND worker_id=? AND instance_id=?`,\\n args:[endpointHost,worker,instance]\\n });\\n return json({ok:true,id,state:r.rows[0].state,worker_id:worker,instance_id:instance});\\n }\\n return json({ok:false,error:\\\"NOT_FOUND\\\"},404);\\n}\\n\",\"legacy_lease_horizon_test.ts\":\"import { sqlite } from \\\"https://esm.town/v/std/sqlite/main.ts\\\";\\nimport { LEASE_SECONDS, healthHttpStatus, legacyLeaseRiskLeases } from \\\"./brain_bridge_worker.ts\\\";\\n\\nconst T=\\\"legacy_lease_horizon_z7p3_\\\"+crypto.randomUUID().replaceAll(\\\"-\\\",\\\"\\\");\\nconst out:any={tests:[],failures:[]};\\nconst ok=(name:string,cond:boolean,detail:any={})=>{out.tests.push({name,ok:!!cond,detail});if(!cond)out.failures.push(name)};\\n\\nawait sqlite.execute(`CREATE TABLE ${T}(\\n endpoint_host TEXT NOT NULL,worker_id TEXT NOT NULL,instance_id TEXT NOT NULL,last_poll_at TEXT\\n)`);\\ntry{\\n const worker=\\\"project-brain-live-v1-worker-v2\\\";\\n await sqlite.execute({sql:`INSERT INTO ${T} VALUES\\n ('main.example',?,'LEGACY_UNATTESTED_INSTANCE',datetime('now','-100 seconds')),\\n ('main.example',?,'attested-new',datetime('now'))`,args:[worker,worker]});\\n const recent:any=await sqlite.execute({sql:`SELECT COUNT(*) AS n FROM ${T}\\n WHERE endpoint_host='main.example' AND worker_id=? AND last_poll_at>=datetime('now','-90 seconds')`,args:[worker]});\\n const risk:any=await sqlite.execute({sql:`SELECT COUNT(*) AS n FROM ${T}\\n WHERE endpoint_host='main.example' AND worker_id=? AND instance_id='LEGACY_UNATTESTED_INSTANCE'\\n AND last_poll_at>=datetime('now','-' || ? || ' seconds')`,args:[worker,LEASE_SECONDS]});\\n const recentCount=Number(recent.rows?.[0]?.n||0);\\n const riskCount=Number(risk.rows?.[0]?.n||0);\\n const legacyActive=legacyLeaseRiskLeases(1,riskCount);\\n ok(\\\"legacy_100s_not_recent_but_within_180s_lease_horizon\\\",recentCount===1 && riskCount===1,{recentCount,riskCount});\\n ok(\\\"live_legacy_origin_risk_fails_health_closed\\\",healthHttpStatus(\\\"HEALTHY\\\",0,0,legacyActive,recentCount)===503,{legacyActive,recentCount});\\n\\n ok(\\\"legacy_risk_without_active_lease_does_not_false_fail\\\",legacyLeaseRiskLeases(0,riskCount)===0);\\n ok(\\\"no_legacy_risk_with_active_attested_lease_can_be_healthy\\\",\\n healthHttpStatus(\\\"HEALTHY\\\",0,0,legacyLeaseRiskLeases(1,0),1)===200);\\n\\n await sqlite.execute({sql:`UPDATE ${T} SET last_poll_at=datetime('now','-181 seconds')\\n WHERE endpoint_host='main.example' AND instance_id='LEGACY_UNATTESTED_INSTANCE'`});\\n const past:any=await sqlite.execute({sql:`SELECT COUNT(*) AS n FROM ${T}\\n WHERE endpoint_host='main.example' AND worker_id=? AND instance_id='LEGACY_UNATTESTED_INSTANCE'\\n AND last_poll_at>=datetime('now','-' || ? || ' seconds')`,args:[worker,LEASE_SECONDS]});\\n ok(\\\"legacy_older_than_max_lease_horizon_no_longer_counts\\\",Number(past.rows?.[0]?.n||0)===0,{row:past.rows?.[0]});\\n\\n out.summary={passed:out.tests.filter((x:any)=>x.ok).length,failed:out.failures.length,total:out.tests.length};\\n console.log(JSON.stringify(out,null,2));\\n}finally{\\n await sqlite.execute(`DROP TABLE IF EXISTS ${T}`);\\n}\\nif(out.failures.length)throw new Error(\\\"LEGACY_LEASE_HORIZON_TEST_FAILURE:\\\"+out.failures.join(\\\",\\\"));\",\"instance_affinity_gap_test.ts\":\"import { sqlite } from \\\"https://esm.town/v/std/sqlite/main.ts\\\";\\nimport { healthHttpStatus, resultSql } from \\\"./brain_bridge_worker.ts\\\";\\n\\nconst JOBS=\\\"instance_affinity_gap_jobs_z7p3\\\";\\nconst WORKERS=\\\"instance_affinity_gap_workers_z7p3\\\";\\nconst out:any={tests:[],failures:[]};\\nconst ok=(name:string,cond:boolean,detail:any={})=>{out.tests.push({name,ok:!!cond,detail});if(!cond)out.failures.push(name)};\\n\\nawait sqlite.execute(`DROP TABLE IF EXISTS ${JOBS}`);\\nawait sqlite.execute(`DROP TABLE IF EXISTS ${WORKERS}`);\\nawait sqlite.execute(`CREATE TABLE ${JOBS}(\\n id TEXT PRIMARY KEY, priority REAL NOT NULL DEFAULT 0, op TEXT NOT NULL, payload_json TEXT NOT NULL,\\n state TEXT NOT NULL DEFAULT 'READY', lease_owner TEXT, lease_expires_at TEXT, result_json TEXT,error_json TEXT,\\n created_at TEXT NOT NULL, updated_at TEXT NOT NULL\\n)`);\\nawait sqlite.execute(`CREATE TABLE ${WORKERS}(\\n endpoint_host TEXT NOT NULL, worker_id TEXT NOT NULL, instance_id TEXT NOT NULL,\\n last_poll_at TEXT,last_result_at TEXT,lease_count INTEGER NOT NULL DEFAULT 0,result_count INTEGER NOT NULL DEFAULT 0,\\n PRIMARY KEY(endpoint_host,worker_id,instance_id)\\n)`);\\ntry{\\n const worker=\\\"project-brain-live-v1-worker-v2\\\";\\n await sqlite.execute({sql:`INSERT INTO ${WORKERS} VALUES\\n ('main.example',?,'LEGACY_UNATTESTED_INSTANCE',datetime('now','-100 seconds'),datetime('now','-100 seconds'),1,0),\\n ('main.example',?,'attested-new',datetime('now'),NULL,0,0)`,args:[worker,worker]});\\n await sqlite.execute({sql:`INSERT INTO ${JOBS}\\n (id,priority,op,payload_json,state,lease_owner,lease_expires_at,created_at,updated_at)\\n VALUES('legacy-origin',1,'brain','{\\\"args\\\":[\\\"verify-chain\\\"],\\\"timeout\\\":60}','LEASED',?,datetime('now','+80 seconds'),datetime('now','-100 seconds'),datetime('now','-100 seconds'))`,args:[worker]});\\n\\n const latest:any=await sqlite.execute({sql:`SELECT instance_id FROM ${WORKERS}\\n WHERE endpoint_host='main.example' AND worker_id=? ORDER BY last_poll_at DESC LIMIT 1`,args:[worker]});\\n const recent:any=await sqlite.execute({sql:`SELECT COUNT(*) AS n FROM ${WORKERS}\\n WHERE endpoint_host='main.example' AND worker_id=? AND last_poll_at>=datetime('now','-90 seconds')`,args:[worker]});\\n const leased:any=await sqlite.execute(`SELECT COUNT(*) AS n FROM ${JOBS} WHERE state='LEASED' AND lease_expires_at>datetime('now')`);\\n const selected=String(latest.rows?.[0]?.instance_id||\\\"\\\");\\n const recentCount=Number(recent.rows?.[0]?.n||0);\\n const leasedCount=Number(leased.rows?.[0]?.n||0);\\n const currentLegacyActive=(selected===\\\"LEGACY_UNATTESTED_INSTANCE\\\")?leasedCount:0;\\n const currentStatus=healthHttpStatus(\\\"HEALTHY\\\",0,0,currentLegacyActive,recentCount);\\n ok(\\\"pre_repair_legacy_origin_false_green_reproduced\\\",currentStatus===200,{\\n selected,recentCount,leasedCount,currentLegacyActive,currentStatus,\\n explanation:\\\"legacy heartbeat is older than STALE_SECONDS but its 180s lease is still live\\\"\\n });\\n\\n // Current result predicate has no instance identity. A different instance sharing the logical worker id\\n // can complete the live lease. This is recorded as a bounded affinity counterexample, not yet a required\\n // production repair in this test.\\n const cross:any=await sqlite.execute({sql:resultSql(JOBS),args:[\\n \\\"COMPLETE\\\",JSON.stringify({from_instance:\\\"attested-new\\\"}),null,\\\"legacy-origin\\\",worker\\n ]});\\n const crossAccepted=(cross.rows?.length||0)===1;\\n ok(\\\"result_path_logical_worker_only_cross_instance_acceptance_reproduced\\\",crossAccepted,{crossAccepted,rows:cross.rows});\\n\\n out.summary={passed:out.tests.filter((x:any)=>x.ok).length,failed:out.failures.length,total:out.tests.length};\\n console.log(JSON.stringify(out,null,2));\\n}finally{\\n await sqlite.execute(`DROP TABLE IF EXISTS ${JOBS}`);\\n await sqlite.execute(`DROP TABLE IF EXISTS ${WORKERS}`);\\n}\\nif(out.failures.length)throw new Error(\\\"COUNTEREXAMPLE_REPRODUCTION_FAILURE:\\\"+out.failures.join(\\\",\\\"));\",\"instance_affinity_pure_runner.ts\":\"import legacyHealth from \\\"./legacy_active_health_test.ts\\\";\\nimport heartbeatScope from \\\"./heartbeat_scope_test.ts\\\";\\n\\nconst results:any[]=[];\\nfor(const [name,fn] of [[\\\"legacy_active_health_test\\\",legacyHealth],[\\\"heartbeat_scope_test\\\",heartbeatScope]] as const){\\n try{\\n const r=fn();\\n results.push({name,ok:true,result:r});\\n }catch(e){\\n results.push({name,ok:false,error:String(e)});\\n }\\n}\\nconsole.log(JSON.stringify(results,null,2));\\nif(results.some(x=>!x.ok))throw new Error(\\\"PURE_REGRESSION_FAILURE\\\");\",\"instance_affinity_test.ts\":\"import { sqlite } from \\\"https://esm.town/v/std/sqlite/main.ts\\\";\\nimport { isAttestedInstance, leaseOneSql } from \\\"./brain_bridge_worker.ts\\\";\\nconst T=\\\"bridge_instance_affinity_test_0140\\\";\\nconst out:any={tests:[],failures:[]};\\nconst ok=(name:string,cond:boolean,detail:any={})=>{out.tests.push({name,ok:!!cond,detail});if(!cond)out.failures.push(name)};\\nconst ex=(sql:string,args:any[]=[])=>sqlite.execute({sql,args});\\nawait sqlite.execute(`DROP TABLE IF EXISTS ${T}`);\\nawait sqlite.execute(`CREATE TABLE ${T}(\\n id TEXT PRIMARY KEY,priority REAL NOT NULL DEFAULT 0,op TEXT NOT NULL,payload_json TEXT NOT NULL,\\n state TEXT NOT NULL DEFAULT 'READY',lease_owner TEXT,lease_expires_at TEXT,result_json TEXT,error_json TEXT,\\n created_at TEXT NOT NULL,updated_at TEXT NOT NULL\\n)`);\\ntry{\\n ok(\\\"legacy_not_attested\\\",!isAttestedInstance(\\\"LEGACY_UNATTESTED_INSTANCE\\\"));\\n ok(\\\"uuid_attested\\\",isAttestedInstance(\\\"c7d7f290-2f43-4fda-a997-e2133962ac83\\\"));\\n const ordinary=JSON.stringify({args:[\\\"verify-chain\\\"],timeout:60});\\n const recover=JSON.stringify({args:[\\\"recover-stale\\\"],timeout:60});\\n\\n await ex(`INSERT INTO ${T}(id,priority,op,payload_json,state,created_at,updated_at) VALUES\\n ('recover',1e300,'brain',?,'READY','2026-01-01 00:00:00','2026-01-01 00:00:00'),\\n ('ordinary',1e300,'brain',?,'READY','2026-01-01 00:00:01','2026-01-01 00:00:01')`,[recover,ordinary]);\\n let r:any=await ex(leaseOneSql(T,false),[\\\"worker\\\",\\\"worker\\\"]);\\n ok(\\\"legacy_skips_recovery_and_leases_ordinary\\\",r.rows?.[0]?.id===\\\"ordinary\\\",{row:r.rows?.[0]});\\n\\n await ex(`DELETE FROM ${T}`);\\n await ex(`INSERT INTO ${T}(id,priority,op,payload_json,state,created_at,updated_at)\\n VALUES('recover',1e300,'brain',?,'READY','2026-01-01 00:00:00','2026-01-01 00:00:00')`,[recover]);\\n r=await ex(leaseOneSql(T,false),[\\\"worker\\\",\\\"worker\\\"]);\\n ok(\\\"legacy_with_only_recovery_gets_no_job\\\",(r.rows?.length||0)===0,{rows:r.rows});\\n\\n r=await ex(leaseOneSql(T,true),[\\\"worker\\\",\\\"worker\\\"]);\\n ok(\\\"attested_instance_can_lease_recovery\\\",r.rows?.[0]?.id===\\\"recover\\\",{row:r.rows?.[0]});\\n\\n out.summary={passed:out.tests.filter((x:any)=>x.ok).length,failed:out.failures.length,total:out.tests.length};\\n console.log(JSON.stringify(out,null,2));\\n}finally{await sqlite.execute(`DROP TABLE IF EXISTS ${T}`)}\\nif(out.failures.length)throw new Error(\\\"TEST_FAILURE:\\\"+out.failures.join(\\\",\\\"));\",\"heartbeat_scope_integration.ts\":\"import { sqlite } from \\\"https://esm.town/v/std/sqlite/main.ts\\\";\\nimport { healthHttpStatus } from \\\"./brain_bridge_worker.ts\\\";\\nconst T=\\\"heartbeat_scope_integration_0144\\\";\\nconst out:any={tests:[],failures:[]};\\nconst ok=(name:string,cond:boolean,detail:any={})=>{out.tests.push({name,ok:!!cond,detail});if(!cond)out.failures.push(name)};\\nawait sqlite.execute(`DROP TABLE IF EXISTS ${T}`);\\nawait sqlite.execute(`CREATE TABLE ${T}(\\n endpoint_host TEXT NOT NULL,worker_id TEXT NOT NULL,instance_id TEXT NOT NULL,\\n last_poll_at TEXT,last_result_at TEXT,lease_count INTEGER NOT NULL DEFAULT 0,\\n result_count INTEGER NOT NULL DEFAULT 0,PRIMARY KEY(endpoint_host,worker_id,instance_id)\\n)`);\\ntry{\\n await sqlite.execute(`INSERT INTO ${T} VALUES\\n ('main.example','project-brain-live-v1-worker-v2','LEGACY_UNATTESTED_INSTANCE',datetime('now','-1 second'),datetime('now','-1 second'),110,106),\\n ('main.example','project-brain-live-v1-worker-v2','c7d7f290-2f43-4fda-a997-e2133962ac83',datetime('now','-2 seconds'),datetime('now','-190 seconds'),12,11),\\n ('main.example','project-brain-live-v1-worker-v2','70d03cb9-a66b-4bfd-8186-070849e9fc09',datetime('now','-3 seconds'),NULL,0,0),\\n ('candidate.example','project-brain-live-v1-worker-v2','candidate-only',datetime('now'),datetime('now'),1,1)`);\\n const main:any=await sqlite.execute(`SELECT COUNT(*) AS n FROM ${T}\\n WHERE endpoint_host='main.example' AND worker_id='project-brain-live-v1-worker-v2'\\n AND last_poll_at>=datetime('now','-90 seconds')`);\\n const candidate:any=await sqlite.execute(`SELECT COUNT(*) AS n FROM ${T}\\n WHERE endpoint_host='candidate.example' AND worker_id='project-brain-live-v1-worker-v2'\\n AND last_poll_at>=datetime('now','-90 seconds')`);\\n ok(\\\"three_recent_main_instances_detected\\\",Number(main.rows?.[0]?.n)===3,{row:main.rows?.[0]});\\n ok(\\\"candidate_endpoint_isolated\\\",Number(candidate.rows?.[0]?.n)===1,{row:candidate.rows?.[0]});\\n ok(\\\"main_three_instances_health_503\\\",healthHttpStatus(\\\"HEALTHY\\\",0,0,0,Number(main.rows?.[0]?.n))===503);\\n ok(\\\"candidate_single_instance_can_be_200\\\",healthHttpStatus(\\\"HEALTHY\\\",0,0,0,Number(candidate.rows?.[0]?.n))===200);\\n out.summary={passed:out.tests.filter((x:any)=>x.ok).length,failed:out.failures.length,total:out.tests.length};\\n console.log(JSON.stringify(out,null,2));\\n}finally{await sqlite.execute(`DROP TABLE IF EXISTS ${T}`)}\\nif(out.failures.length)throw new Error(\\\"TEST_FAILURE:\\\"+out.failures.join(\\\",\\\"));\",\"brain_bridge_recovery_first_test_0120.ts\":\"import { sqlite } from \\\"https://esm.town/v/std/sqlite/main.ts\\\";\\nimport { leaseOneSql } from \\\"./brain_bridge_worker.ts\\\";\\n\\nconst T=\\\"brain_bridge_recovery_first_test_0120\\\";\\nconst out:any={tests:[],failures:[]};\\nconst ok=(name:string,cond:boolean,detail:any={})=>{out.tests.push({name,ok:!!cond,detail});if(!cond)out.failures.push(name)};\\nconst ex=(sql:string,args:any[]=[])=>sqlite.execute({sql,args});\\n\\nawait sqlite.execute(`DROP TABLE IF EXISTS ${T}`);\\nawait sqlite.execute(`CREATE TABLE ${T}(\\n id TEXT PRIMARY KEY,\\n priority REAL NOT NULL DEFAULT 0,\\n op TEXT NOT NULL,\\n payload_json TEXT NOT NULL,\\n state TEXT NOT NULL DEFAULT 'READY',\\n lease_owner TEXT,\\n lease_expires_at TEXT,\\n result_json TEXT,\\n error_json TEXT,\\n created_at TEXT NOT NULL,\\n updated_at TEXT NOT NULL\\n)`);\\n\\ntry{\\n const ordinary=JSON.stringify({args:[\\\"status\\\"],timeout:60});\\n const recover=JSON.stringify({args:[\\\"recover-stale\\\"],timeout:60});\\n const recoverExtraArg=JSON.stringify({args:[\\\"recover-stale\\\",\\\"oops\\\"],timeout:60});\\n const recoverExtraKey=JSON.stringify({args:[\\\"recover-stale\\\"],timeout:60,extra:true});\\n const recoverBadTimeout=JSON.stringify({args:[\\\"recover-stale\\\"],timeout:121});\\n const oldAlias=JSON.stringify({args:[\\\"recover-leases\\\"],timeout:60});\\n\\n await ex(`INSERT INTO ${T}(id,priority,op,payload_json,state,created_at,updated_at) VALUES\\n ('ordinary-old',1e300,'brain',?,'READY','2026-01-01 00:00:00','2026-01-01 00:00:00'),\\n ('recover-valid',1e300,'brain',?,'READY','2026-01-01 00:00:10','2026-01-01 00:00:10')`,[ordinary,recover]);\\n let r:any=await ex(leaseOneSql(T),[\\\"w\\\",\\\"w\\\"]);\\n ok(\\\"valid_recover_preempts_older_overcap_ordinary\\\",r.rows?.[0]?.id===\\\"recover-valid\\\",{row:r.rows?.[0]});\\n await ex(`UPDATE ${T} SET state='READY',lease_owner=NULL,lease_expires_at=NULL WHERE id='recover-valid'`);\\n\\n await ex(`DELETE FROM ${T}`);\\n await ex(`INSERT INTO ${T}(id,priority,op,payload_json,state,created_at,updated_at) VALUES\\n ('ordinary-old',1e300,'brain',?,'READY','2026-01-01 00:00:00','2026-01-01 00:00:00'),\\n ('recover-extra-arg',1e300,'brain',?,'READY','2026-01-01 00:00:01','2026-01-01 00:00:01'),\\n ('recover-extra-key',1e300,'brain',?,'READY','2026-01-01 00:00:02','2026-01-01 00:00:02'),\\n ('recover-bad-timeout',1e300,'brain',?,'READY','2026-01-01 00:00:03','2026-01-01 00:00:03'),\\n ('recover-old-alias',1e300,'brain',?,'READY','2026-01-01 00:00:04','2026-01-01 00:00:04')`,\\n [ordinary,recoverExtraArg,recoverExtraKey,recoverBadTimeout,oldAlias]);\\n r=await ex(leaseOneSql(T),[\\\"w2\\\",\\\"w2\\\"]);\\n ok(\\\"invalid_recovery_shapes_do_not_preempt\\\",r.rows?.[0]?.id===\\\"ordinary-old\\\",{row:r.rows?.[0]});\\n\\n await ex(`DELETE FROM ${T}`);\\n await ex(`INSERT INTO ${T}(id,priority,op,payload_json,state,created_at,updated_at) VALUES\\n ('fifo-a',1e300,'brain',?,'READY','2026-01-01 00:00:00','2026-01-01 00:00:00'),\\n ('fifo-b',1e300,'brain',?,'READY','2026-01-01 00:00:01','2026-01-01 00:00:01')`,[ordinary,ordinary]);\\n r=await ex(leaseOneSql(T),[\\\"w3\\\",\\\"w3\\\"]);\\n ok(\\\"ordinary_overcap_fifo_preserved\\\",r.rows?.[0]?.id===\\\"fifo-a\\\",{row:r.rows?.[0]});\\n\\n await ex(`DELETE FROM ${T}`);\\n await ex(`INSERT INTO ${T}(id,priority,op,payload_json,state,created_at,updated_at,lease_owner,lease_expires_at) VALUES\\n ('active',1,'brain',?,'LEASED','2026-01-01 00:00:00','2026-01-01 00:00:00','w4',datetime('now','+60 seconds')),\\n ('recover-valid',1e300,'brain',?,'READY','2026-01-01 00:00:01','2026-01-01 00:00:01',NULL,NULL)`,[ordinary,recover]);\\n r=await ex(leaseOneSql(T),[\\\"w4\\\",\\\"w4\\\"]);\\n ok(\\\"single_flight_still_blocks_recovery_for_busy_same_worker\\\",(r.rows?.length||0)===0,{rows:r.rows});\\n\\n out.summary={passed:out.tests.filter((x:any)=>x.ok).length,failed:out.failures.length,total:out.tests.length};\\n console.log(JSON.stringify(out,null,2));\\n}finally{\\n await sqlite.execute(`DROP TABLE IF EXISTS ${T}`);\\n}\\nif(out.failures.length) throw new Error(\\\"TEST_FAILURE:\\\"+out.failures.join(\\\",\\\"));\",\"brain_bridge_worker_v5_rebased_test.ts\":\"import { sqlite } from \\\"https://esm.town/v/std/sqlite/main.ts\\\";\\nimport {\\n activeLeaseDecision,activeLeaseSql,LEASE_SECONDS,leaseOneSql,MAX_JOB_TIMEOUT,\\n normalizeDispatch,PRIORITY_CAP,recoverExpiredSql,resultSql,SUPPORTED_BRAIN_COMMANDS\\n} from \\\"./brain_bridge_worker_v5_rebased_candidate.ts\\\";\\n\\nconst T=\\\"brain_bridge_jobs_v5_test_\\\"+crypto.randomUUID().replaceAll(\\\"-\\\",\\\"\\\");\\nconst out:any={tests:[],failures:[]};\\nfunction ok(name:string,cond:boolean,detail:any={}){out.tests.push({name,ok:!!cond,detail});if(!cond)out.failures.push(name);}\\nasync function ex(sql:string,args:any[]=[]){return await sqlite.execute({sql,args});}\\nconst oldV4Sql=(table:string)=>`UPDATE ${table}\\n SET state='LEASED',lease_owner=?,lease_expires_at=datetime('now','+90 seconds'),updated_at=datetime('now')\\n WHERE id=(SELECT id FROM ${table} WHERE state='READY'\\n ORDER BY CASE WHEN priority > ${PRIORITY_CAP} THEN ${PRIORITY_CAP} ELSE priority END DESC,created_at,id LIMIT 1)\\n RETURNING id`;\\n\\nawait sqlite.execute(`DROP TABLE IF EXISTS ${T}`);\\nawait sqlite.execute(`CREATE TABLE ${T}(\\n id TEXT PRIMARY KEY,priority REAL NOT NULL DEFAULT 0,op TEXT NOT NULL,payload_json TEXT NOT NULL,\\n state TEXT NOT NULL DEFAULT 'READY',lease_owner TEXT,lease_expires_at TEXT,result_json TEXT,error_json TEXT,\\n created_at TEXT NOT NULL,updated_at TEXT NOT NULL)`);\\ntry{\\n const p=JSON.stringify({args:[\\\"status\\\"],timeout:60});\\n for(let i=0;i<64;i++){\\n const id=\\\"job-\\\"+String(i).padStart(3,\\\"0\\\");\\n await ex(`INSERT INTO ${T}(id,priority,op,payload_json,state,created_at,updated_at)\\n VALUES(?,?, 'brain',?,'READY',?,?)`,\\n [id,64-i,p,\\\"2026-01-01 00:00:\\\"+String(i%60).padStart(2,\\\"0\\\"),\\\"2026-01-01 00:00:00\\\"]);\\n }\\n\\n const old:any[]=await Promise.all(Array.from({length:16},()=>ex(oldV4Sql(T),[\\\"dup-worker\\\"])));\\n const oldIds=old.flatMap(x=>(x.rows||[]).map((r:any)=>r.id));\\n const oldActive:any=await ex(activeLeaseSql(T),[\\\"dup-worker\\\"]);\\n ok(\\\"live_v4_toctou_reproduced\\\",oldIds.length>1 && oldActive.rows.length>1,{leased_count:oldIds.length,active_count:oldActive.rows.length});\\n\\n await ex(`UPDATE ${T} SET state='READY',lease_owner=NULL,lease_expires_at=NULL,result_json=NULL,error_json=NULL`);\\n const fresh:any[]=await Promise.all(Array.from({length:32},()=>ex(leaseOneSql(T),[\\\"dup-worker\\\",\\\"dup-worker\\\"])));\\n const freshIds=fresh.flatMap(x=>(x.rows||[]).map((r:any)=>r.id));\\n const freshActive:any=await ex(activeLeaseSql(T),[\\\"dup-worker\\\"]);\\n ok(\\\"rebased_atomic_single_flight\\\",freshIds.length===1 && freshActive.rows.length===1,{leased_count:freshIds.length,active_count:freshActive.rows.length,id:freshIds[0]});\\n ok(\\\"active_lease_busy_not_redeliver\\\",activeLeaseDecision(freshActive.rows).kind===\\\"busy\\\",activeLeaseDecision(freshActive.rows));\\n\\n const workers=Array.from({length:16},(_,i)=>\\\"independent-\\\"+i);\\n const indep:any[]=await Promise.all(workers.map(w=>ex(leaseOneSql(T),[w,w])));\\n const indepIds=indep.flatMap(x=>(x.rows||[]).map((r:any)=>r.id));\\n ok(\\\"distinct_workers_progress\\\",indepIds.length===16 && new Set(indepIds).size===16,{count:indepIds.length});\\n\\n // Command surface.\\n for(const cmd of SUPPORTED_BRAIN_COMMANDS){\\n ok(\\\"command_allowed:\\\"+cmd,normalizeDispatch(\\\"brain\\\",JSON.stringify({args:[cmd],timeout:60})).ok);\\n }\\n for(const cmd of [\\\"boot\\\",\\\"boot-agent\\\",\\\"recover-leases\\\",\\\"recover-stale\\\",\\\"record-external-artifact\\\",\\\"init\\\",\\\"nonsense\\\"]){\\n ok(\\\"command_rejected:\\\"+cmd,!normalizeDispatch(\\\"brain\\\",JSON.stringify({args:[cmd],timeout:60})).ok);\\n }\\n ok(\\\"boot_error_precise\\\",(normalizeDispatch(\\\"brain\\\",JSON.stringify({args:[\\\"boot\\\"],timeout:60})) as any).error===\\\"BOOT_NOT_ATOMIC_USE_REGISTER_AGENT_THEN_CLAIM\\\");\\n ok(\\\"timeout_1_allowed\\\",normalizeDispatch(\\\"brain\\\",JSON.stringify({args:[\\\"status\\\"],timeout:1})).ok);\\n ok(\\\"timeout_120_allowed\\\",normalizeDispatch(\\\"brain\\\",JSON.stringify({args:[\\\"status\\\"],timeout:120})).ok);\\n for(const timeout of [0,-1,121,999999,\\\"60\\\",null]){\\n ok(\\\"timeout_rejected:\\\"+String(timeout),!normalizeDispatch(\\\"brain\\\",JSON.stringify({args:[\\\"status\\\"],timeout})).ok);\\n }\\n ok(\\\"brain_schema_closed\\\",!normalizeDispatch(\\\"brain\\\",JSON.stringify({args:[\\\"status\\\"],timeout:60,evil:true})).ok);\\n\\n ok(\\\"read_join_allowed\\\",normalizeDispatch(\\\"read_text\\\",JSON.stringify({path:\\\"/brain/JOIN_PROTOCOL.md\\\",max_bytes:200000})).ok);\\n ok(\\\"read_artifact_allowed\\\",normalizeDispatch(\\\"read_text\\\",JSON.stringify({path:\\\"/brain/artifacts/x.json\\\",max_bytes:1})).ok);\\n for(const q of [\\n {path:\\\"/brain/artifacts/../brain.db\\\",max_bytes:10},\\n {path:\\\"/brain/artifacts/\\\",max_bytes:10},\\n {path:\\\"/etc/passwd\\\",max_bytes:10},\\n {path:\\\"/brain/artifacts/x\\\",max_bytes:200001},\\n {path:\\\"/brain/artifacts/x\\\",max_bytes:10,extra:true}\\n ]) ok(\\\"read_rejected:\\\"+JSON.stringify(q),!normalizeDispatch(\\\"read_text\\\",JSON.stringify(q)).ok);\\n\\n // Priority cap means over-cap jobs are FIFO instead of escalating an arms race.\\n await ex(`UPDATE ${T} SET state='COMPLETE',lease_owner=NULL,lease_expires_at=NULL`);\\n await ex(`INSERT INTO ${T}(id,priority,op,payload_json,state,created_at,updated_at) VALUES\\n ('overcap-old',1e300,'brain',?,'READY','2026-01-01 00:00:00','2026-01-01 00:00:00'),\\n ('overcap-new',1e301,'brain',?,'READY','2026-01-02 00:00:00','2026-01-02 00:00:00')`,[p,p]);\\n const cap:any=await ex(leaseOneSql(T),[\\\"cap-worker\\\",\\\"cap-worker\\\"]);\\n ok(\\\"priority_cap_fifo_over_cap\\\",cap.rows?.[0]?.id===\\\"overcap-old\\\",{row:cap.rows?.[0]});\\n\\n // Known late-result failure happened ~123 s after poll. New lease is 180 s and max command timeout is 120 s.\\n ok(\\\"lease_exceeds_known_late_result_window\\\",LEASE_SECONDS>123,{LEASE_SECONDS});\\n ok(\\\"lease_exceeds_max_command_timeout\\\",LEASE_SECONDS>MAX_JOB_TIMEOUT,{LEASE_SECONDS,MAX_JOB_TIMEOUT});\\n const capId=cap.rows?.[0]?.id;\\n const accepted:any=await ex(resultSql(T),[\\\"COMPLETE\\\",\\\"{}\\\",\\\"\\\",capId,\\\"cap-worker\\\"]);\\n ok(\\\"in_envelope_result_accepted\\\",(accepted.rows?.length||0)===1,{rows:accepted.rows});\\n\\n // Expired result fails closed and the lease remains recoverable.\\n await ex(`UPDATE ${T} SET state='LEASED',lease_owner='late-worker',lease_expires_at=datetime('now','-1 second') WHERE id='overcap-new'`);\\n const late:any=await ex(resultSql(T),[\\\"COMPLETE\\\",\\\"{}\\\",\\\"\\\", \\\"overcap-new\\\",\\\"late-worker\\\"]);\\n ok(\\\"truly_expired_result_rejected\\\",(late.rows?.length||0)===0);\\n await sqlite.execute(recoverExpiredSql(T));\\n const recovered:any=await ex(`SELECT state,lease_owner FROM ${T} WHERE id='overcap-new'`);\\n ok(\\\"expired_lease_recovered\\\",recovered.rows?.[0]?.state===\\\"READY\\\" && recovered.rows[0].lease_owner===null,{row:recovered.rows?.[0]});\\n\\n out.summary={passed:out.tests.filter((x:any)=>x.ok).length,failed:out.failures.length,total:out.tests.length};\\n console.log(JSON.stringify(out,null,2));\\n}finally{await sqlite.execute(`DROP TABLE IF EXISTS ${T}`)}\\nif(out.failures.length)throw new Error(\\\"V5_REBASE_TEST_FAILURE:\\\"+out.failures.join(\\\",\\\"));\\n\",\"brain_bridge_worker_v3_stress_test.ts\":\"import { sqlite } from \\\"https://esm.town/v/std/sqlite/main.ts\\\";\\nimport { activeLeaseSql, leaseOneSql, recoverExpiredSql } from \\\"./brain_bridge_worker_v3_candidate.ts\\\";\\n\\nconst T=\\\"brain_bridge_jobs_v3_stress_4d71\\\";\\nconst out:any={tests:[],failures:[]};\\nfunction ok(name:string,cond:boolean,detail:any={}){out.tests.push({name,ok:!!cond,detail});if(!cond)out.failures.push(name);}\\nasync function ex(sql:string,args:any[]=[]){return await sqlite.execute({sql,args});}\\nconst oldSql=(table:string)=>`UPDATE ${table}\\n SET state='LEASED',lease_owner=?,lease_expires_at=datetime('now','+90 seconds'),updated_at=datetime('now')\\n WHERE id=(SELECT id FROM ${table} WHERE state='READY' ORDER BY priority DESC,created_at,id LIMIT 1)\\n RETURNING id`;\\n\\nawait sqlite.execute(`DROP TABLE IF EXISTS ${T}`);\\nawait sqlite.execute(`CREATE TABLE ${T}(\\n id TEXT PRIMARY KEY, priority REAL NOT NULL DEFAULT 0, op TEXT NOT NULL, payload_json TEXT NOT NULL,\\n state TEXT NOT NULL DEFAULT 'READY', lease_owner TEXT, lease_expires_at TEXT,\\n result_json TEXT,error_json TEXT,created_at TEXT NOT NULL,updated_at TEXT NOT NULL)`);\\ntry{\\n const p=JSON.stringify({args:[\\\"status\\\"],timeout:60});\\n for(let i=0;i<64;i++){\\n const id=\\\"job-\\\"+String(i).padStart(3,\\\"0\\\");\\n await ex(`INSERT INTO ${T}(id,priority,op,payload_json,state,created_at,updated_at)\\n VALUES(?,?, 'brain',?,'READY',?,?)`,\\n [id,64-i,p,\\\"2026-01-01 00:00:\\\"+String(i%60).padStart(2,\\\"0\\\"),\\\"2026-01-01 00:00:00\\\"]);\\n }\\n\\n const old:any[]=await Promise.all(Array.from({length:16},()=>ex(oldSql(T),[\\\"dup-worker\\\"])));\\n const oldIds=old.flatMap(x=>(x.rows||[]).map((r:any)=>r.id));\\n const oldActive:any=await ex(activeLeaseSql(T),[\\\"dup-worker\\\"]);\\n ok(\\\"baseline_old_sql_reproduces_multi_lease\\\",oldIds.length>1 && oldActive.rows.length>1,{leased_count:oldIds.length,active_count:oldActive.rows.length,first:oldIds.slice(0,5)});\\n\\n await ex(`UPDATE ${T} SET state='READY',lease_owner=NULL,lease_expires_at=NULL,result_json=NULL,error_json=NULL`);\\n\\n const fresh:any[]=await Promise.all(Array.from({length:32},()=>ex(leaseOneSql(T),[\\\"dup-worker\\\",\\\"dup-worker\\\"])));\\n const freshIds=fresh.flatMap(x=>(x.rows||[]).map((r:any)=>r.id));\\n const freshActive:any=await ex(activeLeaseSql(T),[\\\"dup-worker\\\"]);\\n ok(\\\"candidate_32_duplicate_polls_single_lease\\\",freshIds.length===1 && freshActive.rows.length===1,{leased_count:freshIds.length,active_count:freshActive.rows.length,id:freshIds[0]});\\n\\n const workers=Array.from({length:16},(_,i)=>\\\"independent-\\\"+String(i).padStart(2,\\\"0\\\"));\\n const independent:any[]=await Promise.all(workers.map(w=>ex(leaseOneSql(T),[w,w])));\\n const independentIds=independent.flatMap(x=>(x.rows||[]).map((r:any)=>r.id));\\n ok(\\\"candidate_independent_workers_progress\\\",independentIds.length===16 && new Set(independentIds).size===16,{leased_count:independentIds.length,unique:new Set(independentIds).size});\\n\\n const all:any=await ex(`SELECT id,priority,lease_owner FROM ${T} WHERE state='LEASED' ORDER BY priority DESC,created_at,id`);\\n ok(\\\"candidate_deterministic_topology\\\",all.rows[0]?.id===\\\"job-000\\\" && all.rows[0]?.lease_owner===\\\"dup-worker\\\",{first:all.rows[0]});\\n\\n // Expire only dup-worker lease, recover, and ensure exactly that row returns to READY.\\n await ex(`UPDATE ${T} SET lease_expires_at=datetime('now','-1 second') WHERE lease_owner='dup-worker'`);\\n await sqlite.execute(recoverExpiredSql(T));\\n const recovered:any=await ex(`SELECT id,state,lease_owner FROM ${T} WHERE id='job-000'`);\\n ok(\\\"candidate_expired_recovery_preserved\\\",recovered.rows[0]?.state===\\\"READY\\\" && recovered.rows[0]?.lease_owner===null,{row:recovered.rows[0]});\\n\\n const independentStill:any=await ex(`SELECT count(*) AS n FROM ${T} WHERE state='LEASED' AND lease_owner LIKE 'independent-%'`);\\n ok(\\\"recovery_does_not_clear_live_other_workers\\\",Number(independentStill.rows[0]?.n)===16,{count:independentStill.rows[0]?.n});\\n\\n out.summary={passed:out.tests.filter((x:any)=>x.ok).length,failed:out.failures.length,total:out.tests.length};\\n console.log(JSON.stringify(out,null,2));\\n}finally{\\n await sqlite.execute(`DROP TABLE IF EXISTS ${T}`);\\n}\\nif(out.failures.length)throw new Error(\\\"STRESS_FAILURE:\\\"+out.failures.join(\\\",\\\"));\\n\"};\nconst enc=new TextEncoder();\nconst hex=(b:Uint8Array)=>[...b].map(x=>x.toString(16).padStart(2,\"0\")).join(\"\");\nconst out:any[]=[];\nfor(const [path,content] of Object.entries(files)){\n const bytes=enc.encode(content as string);\n const digest=new Uint8Array(await crypto.subtle.digest(\"SHA-256\",bytes));\n out.push({path,bytes:bytes.length,sha256:hex(digest)});\n}\nconsole.log(JSON.stringify(out,null,2));",[],[147,425],"26560c6e-aa9b-467f-9555-c1ca9076b4fc","checkpoint.ts","01a07b80-b4d6-73c0-ae85-432b75ed4873",["D",1788791971867],"import { blob } from \"https://esm.town/v/std/blob/main.ts\";\n\nconst MAX_BYTES = 5 * 1024 * 1024;\nconst SNAP_PREFIX = \"snapshots/brain_snapshot_g\";\n\nfunction json(obj: unknown, status = 200) {\n return new Response(JSON.stringify(obj), {\n status,\n headers: { \"content-type\": \"application/json; charset=utf-8\" },\n });\n}\n\nasync function sha256Hex(bytes: Uint8Array): Promise {\n const digest = await crypto.subtle.digest(\"SHA-256\", bytes);\n return [...new Uint8Array(digest)].map((b) => b.toString(16).padStart(2, \"0\")).join(\"\");\n}\n\nasync function sha256Text(s: string): Promise {\n return sha256Hex(new TextEncoder().encode(s));\n}\n\nfunction validHex64(x: unknown): x is string {\n return typeof x === \"string\" && /^[0-9a-f]{64}$/.test(x);\n}\n\nfunction q(x: unknown): string {\n return JSON.stringify(x);\n}\n\nfunction canonicalEventBytes(e: any): Uint8Array {\n // Python Brain event hashes use canonical JSON with sorted outer keys and the already-canonical payload_json bytes.\n if (typeof e.payload_json !== \"string\") throw new Error(\"BAD_EVENT_PAYLOAD_JSON\");\n try { JSON.parse(e.payload_json); } catch { throw new Error(\"INVALID_EVENT_PAYLOAD_JSON\"); }\n const raw =\n `{\"agent_id\":${q(e.agent_id)},\"event_uuid\":${q(e.event_uuid)},\"payload\":${e.payload_json},\"prev_hash\":${q(e.prev_hash)},\"task_id\":${q(e.task_id)},\"ts\":${q(e.ts)},\"type\":${q(e.type)},\"workstream\":${q(e.workstream)}}`;\n return new TextEncoder().encode(raw);\n}\n\nasync function verifySnapshotInternals(doc: any) {\n const events = Array.isArray(doc?.events) ? doc.events : null;\n const snap = doc?.snapshot;\n if (!events || !snap) throw new Error(\"MALFORMED_SNAPSHOT\");\n if (!Number.isInteger(snap.generation) || snap.generation < 0) throw new Error(\"BAD_GENERATION\");\n if (!validHex64(snap.event_head_hash)) throw new Error(\"BAD_EVENT_HEAD\");\n if (snap.event_count !== events.length) throw new Error(\"EVENT_COUNT_MISMATCH\");\n\n let prev = \"0\".repeat(64);\n let expectedId = 1;\n for (const e of events) {\n if (e.id !== expectedId) throw new Error(\"NONCONTIGUOUS_EVENT_IDS\");\n if (e.prev_hash !== prev) throw new Error(\"BROKEN_PREV_LINK\");\n if (!validHex64(e.event_hash)) throw new Error(\"BAD_EVENT_HASH_FIELD\");\n const computed = await sha256Hex(canonicalEventBytes(e));\n if (computed !== e.event_hash) throw new Error(`EVENT_HASH_MISMATCH:${e.id}`);\n prev = e.event_hash;\n expectedId++;\n }\n if (prev !== snap.event_head_hash) throw new Error(\"HEAD_LINK_MISMATCH\");\n\n for (const r of (Array.isArray(doc.recovery_files) ? doc.recovery_files : [])) {\n if (typeof r?.logical_path !== \"string\" || typeof r?.content_utf8 !== \"string\") {\n throw new Error(\"BAD_RECOVERY_FILE_RECORD\");\n }\n const b = new TextEncoder().encode(r.content_utf8);\n if (b.length !== r.size) throw new Error(`RECOVERY_FILE_SIZE_MISMATCH:${r.logical_path}`);\n if (!validHex64(r.sha256)) throw new Error(`BAD_RECOVERY_FILE_SHA:${r.logical_path}`);\n const h = await sha256Hex(b);\n if (h !== r.sha256) throw new Error(`RECOVERY_FILE_SHA_MISMATCH:${r.logical_path}`);\n }\n\n for (const c of (Array.isArray(snap.claims) ? snap.claims : [])) {\n if (typeof c?.statement_json !== \"string\" || !validHex64(c?.statement_sha256)) {\n throw new Error(`BAD_CLAIM_RECORD:${String(c?.id)}`);\n }\n try { JSON.parse(c.statement_json); } catch { throw new Error(`INVALID_CLAIM_JSON:${String(c.id)}`); }\n const h = await sha256Text(c.statement_json);\n if (h !== c.statement_sha256) throw new Error(`CLAIM_STATEMENT_HASH_MISMATCH:${String(c.id)}`);\n }\n\n return {\n generation: snap.generation,\n event_head_hash: snap.event_head_hash,\n event_count: events.length,\n claim_count: Array.isArray(snap.claims) ? snap.claims.length : 0,\n recovery_file_count: Array.isArray(doc.recovery_files) ? doc.recovery_files.length : 0,\n };\n}\n\nfunction generationFromKey(key: string): number {\n const m = key.match(/^snapshots\\/brain_snapshot_g(\\d+)_([0-9a-f]{16})\\.json$/);\n return m ? Number(m[1]) : -1;\n}\n\nasync function latestEntry() {\n const entries = await blob.list(SNAP_PREFIX);\n const valid = entries.filter((e: any) => generationFromKey(e.key) >= 0);\n valid.sort((a: any, b: any) => {\n const dg = generationFromKey(b.key) - generationFromKey(a.key);\n if (dg !== 0) return dg;\n return String(b.lastModified).localeCompare(String(a.lastModified));\n });\n return valid[0];\n}\n\nexport default async function (req: Request) {\n const token = Deno.env.get(\"BRAIN_CHECKPOINT_TOKEN\");\n if (!token) return json({ ok: false, error: \"SERVER_TOKEN_MISSING\" }, 500);\n if (req.headers.get(\"authorization\") !== `Bearer ${token}`) {\n return json({ ok: false, error: \"UNAUTHORIZED\" }, 401);\n }\n\n if (req.method === \"GET\") {\n const url = new URL(req.url);\n const entry = await latestEntry();\n if (!entry) return json({ ok: false, error: \"NO_SNAPSHOTS\" }, 404);\n const stored = new Uint8Array(await (await blob.get(entry.key)).arrayBuffer());\n const sha256 = await sha256Hex(stored);\n let doc: any;\n try { doc = JSON.parse(new TextDecoder().decode(stored)); }\n catch { return json({ ok: false, error: \"STORED_SNAPSHOT_INVALID_JSON\" }, 500); }\n let verified;\n try { verified = await verifySnapshotInternals(doc); }\n catch (e) { return json({ ok: false, error: String(e instanceof Error ? e.message : e) }, 500); }\n\n if (url.searchParams.get(\"download\") === \"1\") {\n return new Response(stored, {\n status: 200,\n headers: {\n \"content-type\": \"application/json\",\n \"x-brain-key\": entry.key,\n \"x-brain-sha256\": sha256,\n \"x-brain-generation\": String(verified.generation),\n \"x-brain-event-head\": verified.event_head_hash,\n \"x-brain-size\": String(stored.length),\n \"x-brain-provider-verified\": \"event-hashes,recovery-files,claims\",\n },\n });\n }\n\n return json({\n ok: true,\n key: entry.key,\n size: stored.length,\n sha256,\n generation: verified.generation,\n event_head_hash: verified.event_head_hash,\n event_count: verified.event_count,\n claim_count: verified.claim_count,\n recovery_file_count: verified.recovery_file_count,\n provider_verified: [\"event_hashes\", \"recovery_file_hashes\", \"claim_statement_hashes\"],\n classification: \"DURABILITY_ONLY_NONAUTHORITY\",\n });\n }\n\n if (req.method !== \"POST\") return json({ ok: false, error: \"METHOD_NOT_ALLOWED\" }, 405);\n\n const bytes = new Uint8Array(await req.arrayBuffer());\n if (bytes.length === 0 || bytes.length > MAX_BYTES) {\n return json({ ok: false, error: \"SIZE_OUT_OF_RANGE\", size: bytes.length }, 413);\n }\n\n let doc: any;\n try { doc = JSON.parse(new TextDecoder().decode(bytes)); }\n catch { return json({ ok: false, error: \"INVALID_JSON\" }, 400); }\n\n let verified;\n try { verified = await verifySnapshotInternals(doc); }\n catch (e) { return json({ ok: false, error: String(e instanceof Error ? e.message : e) }, 400); }\n\n const sha256 = await sha256Hex(bytes);\n const claimedSha = req.headers.get(\"x-brain-sha256\");\n const claimedGeneration = req.headers.get(\"x-brain-generation\");\n const claimedHead = req.headers.get(\"x-brain-event-head\");\n\n if (claimedSha && claimedSha !== sha256) return json({ ok: false, error: \"SHA_HEADER_MISMATCH\" }, 400);\n if (claimedGeneration && Number(claimedGeneration) !== verified.generation) return json({ ok: false, error: \"GENERATION_HEADER_MISMATCH\" }, 400);\n if (claimedHead && claimedHead !== verified.event_head_hash) return json({ ok: false, error: \"HEAD_HEADER_MISMATCH\" }, 400);\n\n const key = `snapshots/brain_snapshot_g${verified.generation}_${sha256.slice(0, 16)}.json`;\n await blob.set(key, bytes);\n\n const readback = new Uint8Array(await (await blob.get(key)).arrayBuffer());\n const readbackSha = await sha256Hex(readback);\n if (readback.length !== bytes.length || readbackSha !== sha256) {\n return json({ ok: false, error: \"PROVIDER_READBACK_MISMATCH\" }, 500);\n }\n\n return json({\n ok: true,\n provider: \"val-town\",\n key,\n size: bytes.length,\n sha256,\n generation: verified.generation,\n event_head_hash: verified.event_head_hash,\n event_count: verified.event_count,\n claim_count: verified.claim_count,\n recovery_file_count: verified.recovery_file_count,\n provider_verified: [\"event_hashes\", \"recovery_file_hashes\", \"claim_statement_hashes\", \"readback_sha256\"],\n classification: \"DURABILITY_ONLY_NONAUTHORITY\",\n });\n}",[],[147,432],"7c67938f-b05a-4373-93d9-fee39f314932","brain_bridge_worker_v5_rebased_test.ts","01a07b80-b4d6-73c0-ae85-4b285eb98c0c",["D",1788791971867],"import { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\nimport {\n activeLeaseDecision,activeLeaseSql,LEASE_SECONDS,leaseOneSql,MAX_JOB_TIMEOUT,\n normalizeDispatch,PRIORITY_CAP,recoverExpiredSql,resultSql,SUPPORTED_BRAIN_COMMANDS\n} from \"./brain_bridge_worker_v5_rebased_candidate.ts\";\n\nconst T=\"brain_bridge_jobs_v5_test_\"+crypto.randomUUID().replaceAll(\"-\",\"\");\nconst out:any={tests:[],failures:[]};\nfunction ok(name:string,cond:boolean,detail:any={}){out.tests.push({name,ok:!!cond,detail});if(!cond)out.failures.push(name);}\nasync function ex(sql:string,args:any[]=[]){return await sqlite.execute({sql,args});}\nconst oldV4Sql=(table:string)=>`UPDATE ${table}\n SET state='LEASED',lease_owner=?,lease_expires_at=datetime('now','+90 seconds'),updated_at=datetime('now')\n WHERE id=(SELECT id FROM ${table} WHERE state='READY'\n ORDER BY CASE WHEN priority > ${PRIORITY_CAP} THEN ${PRIORITY_CAP} ELSE priority END DESC,created_at,id LIMIT 1)\n RETURNING id`;\n\nawait sqlite.execute(`DROP TABLE IF EXISTS ${T}`);\nawait sqlite.execute(`CREATE TABLE ${T}(\n id TEXT PRIMARY KEY,priority REAL NOT NULL DEFAULT 0,op TEXT NOT NULL,payload_json TEXT NOT NULL,\n state TEXT NOT NULL DEFAULT 'READY',lease_owner TEXT,lease_expires_at TEXT,result_json TEXT,error_json TEXT,\n created_at TEXT NOT NULL,updated_at TEXT NOT NULL)`);\ntry{\n const p=JSON.stringify({args:[\"status\"],timeout:60});\n for(let i=0;i<64;i++){\n const id=\"job-\"+String(i).padStart(3,\"0\");\n await ex(`INSERT INTO ${T}(id,priority,op,payload_json,state,created_at,updated_at)\n VALUES(?,?, 'brain',?,'READY',?,?)`,\n [id,64-i,p,\"2026-01-01 00:00:\"+String(i%60).padStart(2,\"0\"),\"2026-01-01 00:00:00\"]);\n }\n\n const old:any[]=await Promise.all(Array.from({length:16},()=>ex(oldV4Sql(T),[\"dup-worker\"])));\n const oldIds=old.flatMap(x=>(x.rows||[]).map((r:any)=>r.id));\n const oldActive:any=await ex(activeLeaseSql(T),[\"dup-worker\"]);\n ok(\"live_v4_toctou_reproduced\",oldIds.length>1 && oldActive.rows.length>1,{leased_count:oldIds.length,active_count:oldActive.rows.length});\n\n await ex(`UPDATE ${T} SET state='READY',lease_owner=NULL,lease_expires_at=NULL,result_json=NULL,error_json=NULL`);\n const fresh:any[]=await Promise.all(Array.from({length:32},()=>ex(leaseOneSql(T),[\"dup-worker\",\"dup-worker\"])));\n const freshIds=fresh.flatMap(x=>(x.rows||[]).map((r:any)=>r.id));\n const freshActive:any=await ex(activeLeaseSql(T),[\"dup-worker\"]);\n ok(\"rebased_atomic_single_flight\",freshIds.length===1 && freshActive.rows.length===1,{leased_count:freshIds.length,active_count:freshActive.rows.length,id:freshIds[0]});\n ok(\"active_lease_busy_not_redeliver\",activeLeaseDecision(freshActive.rows).kind===\"busy\",activeLeaseDecision(freshActive.rows));\n\n const workers=Array.from({length:16},(_,i)=>\"independent-\"+i);\n const indep:any[]=await Promise.all(workers.map(w=>ex(leaseOneSql(T),[w,w])));\n const indepIds=indep.flatMap(x=>(x.rows||[]).map((r:any)=>r.id));\n ok(\"distinct_workers_progress\",indepIds.length===16 && new Set(indepIds).size===16,{count:indepIds.length});\n\n // Command surface.\n for(const cmd of SUPPORTED_BRAIN_COMMANDS){\n ok(\"command_allowed:\"+cmd,normalizeDispatch(\"brain\",JSON.stringify({args:[cmd],timeout:60})).ok);\n }\n for(const cmd of [\"boot\",\"boot-agent\",\"recover-leases\",\"recover-stale\",\"record-external-artifact\",\"init\",\"nonsense\"]){\n ok(\"command_rejected:\"+cmd,!normalizeDispatch(\"brain\",JSON.stringify({args:[cmd],timeout:60})).ok);\n }\n ok(\"boot_error_precise\",(normalizeDispatch(\"brain\",JSON.stringify({args:[\"boot\"],timeout:60})) as any).error===\"BOOT_NOT_ATOMIC_USE_REGISTER_AGENT_THEN_CLAIM\");\n ok(\"timeout_1_allowed\",normalizeDispatch(\"brain\",JSON.stringify({args:[\"status\"],timeout:1})).ok);\n ok(\"timeout_120_allowed\",normalizeDispatch(\"brain\",JSON.stringify({args:[\"status\"],timeout:120})).ok);\n for(const timeout of [0,-1,121,999999,\"60\",null]){\n ok(\"timeout_rejected:\"+String(timeout),!normalizeDispatch(\"brain\",JSON.stringify({args:[\"status\"],timeout})).ok);\n }\n ok(\"brain_schema_closed\",!normalizeDispatch(\"brain\",JSON.stringify({args:[\"status\"],timeout:60,evil:true})).ok);\n\n ok(\"read_join_allowed\",normalizeDispatch(\"read_text\",JSON.stringify({path:\"/brain/JOIN_PROTOCOL.md\",max_bytes:200000})).ok);\n ok(\"read_artifact_allowed\",normalizeDispatch(\"read_text\",JSON.stringify({path:\"/brain/artifacts/x.json\",max_bytes:1})).ok);\n for(const q of [\n {path:\"/brain/artifacts/../brain.db\",max_bytes:10},\n {path:\"/brain/artifacts/\",max_bytes:10},\n {path:\"/etc/passwd\",max_bytes:10},\n {path:\"/brain/artifacts/x\",max_bytes:200001},\n {path:\"/brain/artifacts/x\",max_bytes:10,extra:true}\n ]) ok(\"read_rejected:\"+JSON.stringify(q),!normalizeDispatch(\"read_text\",JSON.stringify(q)).ok);\n\n // Priority cap means over-cap jobs are FIFO instead of escalating an arms race.\n await ex(`UPDATE ${T} SET state='COMPLETE',lease_owner=NULL,lease_expires_at=NULL`);\n await ex(`INSERT INTO ${T}(id,priority,op,payload_json,state,created_at,updated_at) VALUES\n ('overcap-old',1e300,'brain',?,'READY','2026-01-01 00:00:00','2026-01-01 00:00:00'),\n ('overcap-new',1e301,'brain',?,'READY','2026-01-02 00:00:00','2026-01-02 00:00:00')`,[p,p]);\n const cap:any=await ex(leaseOneSql(T),[\"cap-worker\",\"cap-worker\"]);\n ok(\"priority_cap_fifo_over_cap\",cap.rows?.[0]?.id===\"overcap-old\",{row:cap.rows?.[0]});\n\n // Known late-result failure happened ~123 s after poll. New lease is 180 s and max command timeout is 120 s.\n ok(\"lease_exceeds_known_late_result_window\",LEASE_SECONDS>123,{LEASE_SECONDS});\n ok(\"lease_exceeds_max_command_timeout\",LEASE_SECONDS>MAX_JOB_TIMEOUT,{LEASE_SECONDS,MAX_JOB_TIMEOUT});\n const capId=cap.rows?.[0]?.id;\n const accepted:any=await ex(resultSql(T),[\"COMPLETE\",\"{}\",\"\",capId,\"cap-worker\"]);\n ok(\"in_envelope_result_accepted\",(accepted.rows?.length||0)===1,{rows:accepted.rows});\n\n // Expired result fails closed and the lease remains recoverable.\n await ex(`UPDATE ${T} SET state='LEASED',lease_owner='late-worker',lease_expires_at=datetime('now','-1 second') WHERE id='overcap-new'`);\n const late:any=await ex(resultSql(T),[\"COMPLETE\",\"{}\",\"\", \"overcap-new\",\"late-worker\"]);\n ok(\"truly_expired_result_rejected\",(late.rows?.length||0)===0);\n await sqlite.execute(recoverExpiredSql(T));\n const recovered:any=await ex(`SELECT state,lease_owner FROM ${T} WHERE id='overcap-new'`);\n ok(\"expired_lease_recovered\",recovered.rows?.[0]?.state===\"READY\" && recovered.rows[0].lease_owner===null,{row:recovered.rows?.[0]});\n\n out.summary={passed:out.tests.filter((x:any)=>x.ok).length,failed:out.failures.length,total:out.tests.length};\n console.log(JSON.stringify(out,null,2));\n}finally{await sqlite.execute(`DROP TABLE IF EXISTS ${T}`)}\nif(out.failures.length)throw new Error(\"V5_REBASE_TEST_FAILURE:\"+out.failures.join(\",\"));\n",[],[147,439],"aa489984-cba6-4405-8cc1-42d90466d5a4","brain_bridge_worker_v5_rebased_candidate.ts","01a07b80-b4d6-73c0-ae85-4ff4a80bad28",["D",1788791971867],"import { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\n\nconst WORKER_TOKEN = Deno.env.get(\"BRAIN_BRIDGE_WORKER_TOKEN\") || \"\";\nconst JOB_TABLE = \"brain_bridge_jobs\";\nexport const STALE_SECONDS = 90;\nexport const DEAD_SECONDS = 180;\nexport const PRIORITY_CAP = 1_000_000_000;\nexport const MAX_JOB_TIMEOUT = 120;\nexport const LEASE_SECONDS = 180;\nexport const MAX_READ_BYTES = 200_000;\n\nexport const SUPPORTED_BRAIN_COMMANDS = [\n \"status\",\n \"verify-chain\",\n \"verify-claim-graph\",\n \"register-agent\",\n \"ensure-task\",\n \"delegate-task\",\n \"claim\",\n \"renew-lease\",\n \"commit\",\n \"checkpoint\",\n \"add-claim\",\n \"invalidate-claim\",\n \"supersede-task-context\",\n \"migrate-task-invariants\",\n \"reconcile-causal-blocks\"\n] as const;\nconst SUPPORTED = new Set(SUPPORTED_BRAIN_COMMANDS);\n\nfunction json(v:unknown,status=200){return Response.json(v,{status});}\nfunction tableName(table:string){if(!/^[A-Za-z_][A-Za-z0-9_]*$/.test(table))throw new Error(\"BAD_TABLE\");return table;}\n\nexport function classifyWorkerAge(ageSeconds:number|null){\n if(ageSeconds===null || !Number.isFinite(ageSeconds)) return {state:\"UNKNOWN\",reason:\"NO_WORKER_HEARTBEAT\"};\n if(ageSeconds<=STALE_SECONDS) return {state:\"HEALTHY\",reason:\"RECENT_WORKER_POLL\"};\n if(ageSeconds<=DEAD_SECONDS) return {state:\"DEGRADED\",reason:\"WORKER_POLL_STALE\"};\n return {state:\"DOWN\",reason:\"WORKER_POLL_DEAD\"};\n}\nexport function effectivePriority(x:number){if(!Number.isFinite(x))return 0;return Math.min(x,PRIORITY_CAP);}\nexport function healthHttpStatus(workerState:string,duplicateActiveLeases:number,expiredLeases:number){\n return workerState===\"HEALTHY\" && duplicateActiveLeases===0 && expiredLeases===0 ? 200 : 503;\n}\nexport function activeLeaseDecision(rows:any[]){\n if(rows.length>1)return {kind:\"conflict\" as const,count:rows.length};\n if(rows[0])return {kind:\"busy\" as const,active_job_id:String(rows[0].id),lease_expires_at:rows[0].lease_expires_at};\n return {kind:\"free\" as const};\n}\n\nexport function recoverExpiredSql(table=JOB_TABLE){\n table=tableName(table);\n return `UPDATE ${table}\n SET state='READY',lease_owner=NULL,lease_expires_at=NULL,updated_at=datetime('now')\n WHERE state='LEASED' AND lease_expires_at IS NOT NULL AND lease_expires_at <= datetime('now')`;\n}\nexport function activeLeaseSql(table=JOB_TABLE){\n table=tableName(table);\n return `SELECT id,op,payload_json,priority,lease_expires_at\n FROM ${table}\n WHERE state='LEASED' AND lease_owner=? AND lease_expires_at > datetime('now')\n ORDER BY lease_expires_at,id LIMIT 2`;\n}\nexport function leaseOneSql(table=JOB_TABLE){\n table=tableName(table);\n return `UPDATE ${table}\n SET state='LEASED',lease_owner=?,lease_expires_at=datetime('now','+${LEASE_SECONDS} seconds'),updated_at=datetime('now')\n WHERE id=(\n SELECT j.id FROM ${table} j\n WHERE j.state='READY'\n AND NOT EXISTS(\n SELECT 1 FROM ${table} x\n WHERE x.state='LEASED' AND x.lease_owner=? AND x.lease_expires_at > datetime('now')\n )\n ORDER BY CASE WHEN j.priority > ${PRIORITY_CAP} THEN ${PRIORITY_CAP} 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`;\n}\nexport function resultSql(table=JOB_TABLE){\n table=tableName(table);\n return `UPDATE ${table}\n SET state=?,result_json=?,error_json=?,lease_expires_at=NULL,updated_at=datetime('now')\n WHERE id=? AND state='LEASED' AND lease_owner=? AND lease_expires_at > datetime('now')\n RETURNING id,state`;\n}\n\nexport type DispatchResult=\n | {ok:true;payload_json:string}\n | {ok:false;error:string};\n\nfunction exactKeys(q:any, expected:string[]){\n const got=Object.keys(q).sort();\n const want=[...expected].sort();\n return got.length===want.length && got.every((k,i)=>k===want[i]);\n}\n\nexport function normalizeDispatch(op:string,payloadJson:string):DispatchResult{\n let q:any;try{q=JSON.parse(payloadJson)}catch{return {ok:false,error:\"PAYLOAD_JSON_INVALID\"}}\n if(!q || typeof q!==\"object\" || Array.isArray(q))return {ok:false,error:\"PAYLOAD_OBJECT_REQUIRED\"};\n\n if(op===\"brain\"){\n if(!exactKeys(q,[\"args\",\"timeout\"]))return {ok:false,error:\"BRAIN_PAYLOAD_SCHEMA_NOT_CLOSED\"};\n if(!Array.isArray(q.args) || q.args.length<1 || q.args.some((x:any)=>typeof x!==\"string\"))return {ok:false,error:\"BRAIN_ARGS_INVALID\"};\n if(!Number.isInteger(q.timeout) || q.timeout<1 || q.timeout>MAX_JOB_TIMEOUT)return {ok:false,error:\"BRAIN_TIMEOUT_INVALID\"};\n const cmd=q.args[0];\n if(cmd===\"boot\")return {ok:false,error:\"BOOT_NOT_ATOMIC_USE_REGISTER_AGENT_THEN_CLAIM\"};\n if(cmd===\"boot-agent\")return {ok:false,error:\"RAW_BOOT_AGENT_NOT_BRIDGE_COMMAND\"};\n if(cmd===\"recover-leases\" || cmd===\"recover-stale\")return {ok:false,error:\"RECOVER_LEASE_ALIAS_NOT_AVAILABLE_ON_CURRENT_EXECUTOR\"};\n if(!SUPPORTED.has(cmd))return {ok:false,error:\"BRAIN_SUBCOMMAND_NOT_ALLOWED\"};\n return {ok:true,payload_json:JSON.stringify({args:q.args,timeout:q.timeout})};\n }\n\n if(op===\"read_text\"){\n if(!exactKeys(q,[\"path\",\"max_bytes\"]))return {ok:false,error:\"READ_TEXT_SCHEMA_NOT_CLOSED\"};\n if(typeof q.path!==\"string\")return {ok:false,error:\"READ_TEXT_PATH_REQUIRED\"};\n if(q.path.includes(\"\\0\") || q.path.includes(\"\\\\\") || q.path.split(\"/\").some((s:string)=>s===\".\" || s===\"..\")){\n return {ok:false,error:\"READ_TEXT_TRAVERSAL_REJECTED\"};\n }\n const artifactFile=q.path.startsWith(\"/brain/artifacts/\") && q.path.length>\"/brain/artifacts/\".length && !q.path.endsWith(\"/\");\n if(!(q.path===\"/brain/JOIN_PROTOCOL.md\" || artifactFile))return {ok:false,error:\"READ_TEXT_PATH_FORBIDDEN\"};\n if(!Number.isInteger(q.max_bytes) || q.max_bytes<1 || q.max_bytes>MAX_READ_BYTES)return {ok:false,error:\"READ_TEXT_MAX_BYTES_INVALID\"};\n return {ok:true,payload_json:JSON.stringify({path:q.path,max_bytes:q.max_bytes})};\n }\n return {ok:false,error:\"OP_UNSUPPORTED\"};\n}\n\nasync function ensureTables(){\n await sqlite.execute(`CREATE TABLE IF NOT EXISTS brain_bridge_workers_v4 (\n worker_id TEXT NOT NULL,\n instance_id TEXT NOT NULL,\n first_seen_at TEXT NOT NULL,\n last_poll_at TEXT,\n last_result_at TEXT,\n lease_count INTEGER NOT NULL DEFAULT 0,\n result_count INTEGER NOT NULL DEFAULT 0,\n updated_at TEXT NOT NULL,\n PRIMARY KEY(worker_id,instance_id)\n )`);\n}\nfunction instanceOf(q:any){const v=String(q?.instance_id||\"\").trim();return v||\"LEGACY_UNATTESTED_INSTANCE\";}\n\nasync function workerHealth(){\n await ensureTables();\n const wr:any=await sqlite.execute(`\n SELECT worker_id,instance_id,last_poll_at,last_result_at,lease_count,result_count,\n CAST((julianday('now')-julianday(last_poll_at))*86400 AS INTEGER) AS poll_age_seconds\n FROM brain_bridge_workers_v4\n ORDER BY last_poll_at DESC LIMIT 1`);\n const w=wr.rows?.[0]||null;\n const qc:any=await sqlite.execute({\n sql:`SELECT\n SUM(CASE WHEN state='READY' THEN 1 ELSE 0 END) AS ready_count,\n SUM(CASE WHEN state='LEASED' THEN 1 ELSE 0 END) AS leased_count,\n SUM(CASE WHEN state='LEASED' AND lease_expires_at <= datetime('now') THEN 1 ELSE 0 END) AS expired_lease_count,\n SUM(CASE WHEN state='READY' AND priority > ? THEN 1 ELSE 0 END) AS overcap_ready_count,\n MIN(CASE WHEN state='READY' THEN created_at END) AS oldest_ready_at,\n MIN(CASE WHEN state='LEASED' THEN lease_expires_at END) AS earliest_lease_expiry\n FROM brain_bridge_jobs`,\n args:[PRIORITY_CAP]\n });\n const dup:any=await sqlite.execute(`\n SELECT COUNT(*) AS duplicate_worker_count FROM (\n SELECT lease_owner FROM brain_bridge_jobs\n WHERE state='LEASED' AND lease_expires_at > datetime('now') AND lease_owner IS NOT NULL\n GROUP BY lease_owner HAVING COUNT(*) > 1\n )`);\n const q=qc.rows?.[0]||{};\n const duplicateActiveLeases=Number(dup.rows?.[0]?.duplicate_worker_count||0);\n const cls=classifyWorkerAge(w?Number(w.poll_age_seconds):null);\n const expiredLeases=Number(q.expired_lease_count||0);\n const status=healthHttpStatus(cls.state,duplicateActiveLeases,expiredLeases);\n return {status,body:{\n endpoint_ok:true,\n service:\"brain-bridge-worker-v5-rebased-candidate\",\n worker:w,\n worker_state:cls.state,\n worker_reason:cls.reason,\n instance_identity_available:w ? w.instance_id!==\"LEGACY_UNATTESTED_INSTANCE\" : false,\n duplicate_active_worker_leases:duplicateActiveLeases,\n queue:q,\n transport_priority_cap:PRIORITY_CAP,\n max_brain_timeout_seconds:MAX_JOB_TIMEOUT,\n queue_lease_seconds:LEASE_SECONDS,\n selection_policy:\"CLAMPED_PRIORITY_THEN_FIFO_SINGLE_FLIGHT\",\n atomic_single_flight:true,\n fail_closed_http_status:status\n }};\n}\n\nasync function rejectInvalidLease(worker:string,id:string,error:string){\n await sqlite.execute({\n sql:`UPDATE ${JOB_TABLE}\n SET state='FAILED',result_json=NULL,error_json=?,lease_expires_at=NULL,updated_at=datetime('now')\n WHERE id=? AND state='LEASED' AND lease_owner=?`,\n args:[JSON.stringify({classification:\"BRIDGE_DISPATCH_REJECTED\",error}),id,worker]\n });\n}\n\nexport default async function(req:Request):Promise{\n const u=new URL(req.url);\n if(req.method===\"GET\" && u.pathname.endsWith(\"/health\")){\n const h=await workerHealth();return json(h.body,h.status);\n }\n if(req.method!==\"POST\")return json({ok:false,error:\"METHOD\"},405);\n const supplied=req.headers.get(\"x-brain-worker-token\")||\"\";\n if(!WORKER_TOKEN || supplied!==WORKER_TOKEN)return json({ok:false,error:\"UNAUTHORIZED\"},401);\n let q:any;try{q=await req.json()}catch{return json({ok:false,error:\"BAD_JSON\"},400)}\n await ensureTables();\n\n if(u.pathname.endsWith(\"/poll\")){\n const worker=String(q.worker_id||\"\").trim();\n if(!worker || worker.length>128)return json({ok:false,error:\"WORKER_REQUIRED\"},400);\n const instance=instanceOf(q);\n await sqlite.execute({\n sql:`INSERT INTO brain_bridge_workers_v4(worker_id,instance_id,first_seen_at,last_poll_at,updated_at)\n VALUES(?,?,datetime('now'),datetime('now'),datetime('now'))\n ON CONFLICT(worker_id,instance_id) DO UPDATE SET last_poll_at=datetime('now'),updated_at=datetime('now')`,\n args:[worker,instance]\n });\n\n await sqlite.execute(recoverExpiredSql());\n const ar:any=await sqlite.execute({sql:activeLeaseSql(),args:[worker]});\n const before=activeLeaseDecision(ar.rows||[]);\n if(before.kind===\"conflict\")return json({ok:false,error:\"MULTIPLE_ACTIVE_LEASES\",worker_id:worker,count:before.count},409);\n if(before.kind===\"busy\")return json({ok:true,job:null,reason:\"ACTIVE_LEASE_EXISTS\",active_lease:{id:before.active_job_id,lease_expires_at:before.lease_expires_at},worker_id:worker,instance_id:instance});\n\n const r:any=await sqlite.execute({sql:leaseOneSql(),args:[worker,worker]});\n if(!r.rows?.[0]){\n return json({ok:true,job:null,reason:\"NO_READY_JOB_OR_RACED_ACTIVE_LEASE\",worker_id:worker,instance_id:instance,priority_cap:PRIORITY_CAP});\n }\n\n const row=r.rows[0];\n const normalized=normalizeDispatch(String(row.op),String(row.payload_json));\n if(!normalized.ok){\n await rejectInvalidLease(worker,String(row.id),normalized.error);\n return json({ok:true,job:null,reason:\"DISPATCH_REJECTED\",rejected_job:String(row.id),dispatch_error:normalized.error,worker_id:worker,instance_id:instance});\n }\n\n await sqlite.execute({\n sql:\"UPDATE brain_bridge_workers_v4 SET lease_count=lease_count+1,updated_at=datetime('now') WHERE worker_id=? AND instance_id=?\",\n args:[worker,instance]\n });\n return json({ok:true,job:{...row,payload_json:normalized.payload_json},worker_id:worker,instance_id:instance,priority_cap:PRIORITY_CAP,lease_seconds:LEASE_SECONDS});\n }\n\n if(u.pathname.endsWith(\"/result\")){\n const worker=String(q.worker_id||\"\").trim(),id=String(q.id||\"\").trim(),success=q.success===true;\n const instance=instanceOf(q);\n if(!worker||!id)return json({ok:false,error:\"BAD_RESULT_ID\"},400);\n const r:any=await sqlite.execute({\n sql:resultSql(),\n args:[success?\"COMPLETE\":\"FAILED\",success?JSON.stringify(q.result??null):null,success?null:JSON.stringify(q.error??null),id,worker]\n });\n if(!r.rows?.length)return json({ok:false,error:\"LEASE_MISMATCH_OR_EXPIRED\"},409);\n await sqlite.execute({\n sql:\"UPDATE brain_bridge_workers_v4 SET last_result_at=datetime('now'),result_count=result_count+1,updated_at=datetime('now') WHERE worker_id=? AND instance_id=?\",\n args:[worker,instance]\n });\n return json({ok:true,id,state:r.rows[0].state,worker_id:worker,instance_id:instance});\n }\n return json({ok:false,error:\"NOT_FOUND\"},404);\n}\n",[],[147,446],"05305095-76e8-45ed-bbc1-3be0efe255b3","brain_bridge_worker_v3_stress_test.ts","01a07b80-b4d6-73c0-ae85-5016d7f34723",["D",1788791971867],"import { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\nimport { activeLeaseSql, leaseOneSql, recoverExpiredSql } from \"./brain_bridge_worker_v3_candidate.ts\";\n\nconst T=\"brain_bridge_jobs_v3_stress_4d71\";\nconst out:any={tests:[],failures:[]};\nfunction ok(name:string,cond:boolean,detail:any={}){out.tests.push({name,ok:!!cond,detail});if(!cond)out.failures.push(name);}\nasync function ex(sql:string,args:any[]=[]){return await sqlite.execute({sql,args});}\nconst oldSql=(table:string)=>`UPDATE ${table}\n SET state='LEASED',lease_owner=?,lease_expires_at=datetime('now','+90 seconds'),updated_at=datetime('now')\n WHERE id=(SELECT id FROM ${table} WHERE state='READY' ORDER BY priority DESC,created_at,id LIMIT 1)\n RETURNING id`;\n\nawait sqlite.execute(`DROP TABLE IF EXISTS ${T}`);\nawait sqlite.execute(`CREATE TABLE ${T}(\n id TEXT PRIMARY KEY, priority REAL NOT NULL DEFAULT 0, op TEXT NOT NULL, payload_json TEXT NOT NULL,\n state TEXT NOT NULL DEFAULT 'READY', lease_owner TEXT, lease_expires_at TEXT,\n result_json TEXT,error_json TEXT,created_at TEXT NOT NULL,updated_at TEXT NOT NULL)`);\ntry{\n const p=JSON.stringify({args:[\"status\"],timeout:60});\n for(let i=0;i<64;i++){\n const id=\"job-\"+String(i).padStart(3,\"0\");\n await ex(`INSERT INTO ${T}(id,priority,op,payload_json,state,created_at,updated_at)\n VALUES(?,?, 'brain',?,'READY',?,?)`,\n [id,64-i,p,\"2026-01-01 00:00:\"+String(i%60).padStart(2,\"0\"),\"2026-01-01 00:00:00\"]);\n }\n\n const old:any[]=await Promise.all(Array.from({length:16},()=>ex(oldSql(T),[\"dup-worker\"])));\n const oldIds=old.flatMap(x=>(x.rows||[]).map((r:any)=>r.id));\n const oldActive:any=await ex(activeLeaseSql(T),[\"dup-worker\"]);\n ok(\"baseline_old_sql_reproduces_multi_lease\",oldIds.length>1 && oldActive.rows.length>1,{leased_count:oldIds.length,active_count:oldActive.rows.length,first:oldIds.slice(0,5)});\n\n await ex(`UPDATE ${T} SET state='READY',lease_owner=NULL,lease_expires_at=NULL,result_json=NULL,error_json=NULL`);\n\n const fresh:any[]=await Promise.all(Array.from({length:32},()=>ex(leaseOneSql(T),[\"dup-worker\",\"dup-worker\"])));\n const freshIds=fresh.flatMap(x=>(x.rows||[]).map((r:any)=>r.id));\n const freshActive:any=await ex(activeLeaseSql(T),[\"dup-worker\"]);\n ok(\"candidate_32_duplicate_polls_single_lease\",freshIds.length===1 && freshActive.rows.length===1,{leased_count:freshIds.length,active_count:freshActive.rows.length,id:freshIds[0]});\n\n const workers=Array.from({length:16},(_,i)=>\"independent-\"+String(i).padStart(2,\"0\"));\n const independent:any[]=await Promise.all(workers.map(w=>ex(leaseOneSql(T),[w,w])));\n const independentIds=independent.flatMap(x=>(x.rows||[]).map((r:any)=>r.id));\n ok(\"candidate_independent_workers_progress\",independentIds.length===16 && new Set(independentIds).size===16,{leased_count:independentIds.length,unique:new Set(independentIds).size});\n\n const all:any=await ex(`SELECT id,priority,lease_owner FROM ${T} WHERE state='LEASED' ORDER BY priority DESC,created_at,id`);\n ok(\"candidate_deterministic_topology\",all.rows[0]?.id===\"job-000\" && all.rows[0]?.lease_owner===\"dup-worker\",{first:all.rows[0]});\n\n // Expire only dup-worker lease, recover, and ensure exactly that row returns to READY.\n await ex(`UPDATE ${T} SET lease_expires_at=datetime('now','-1 second') WHERE lease_owner='dup-worker'`);\n await sqlite.execute(recoverExpiredSql(T));\n const recovered:any=await ex(`SELECT id,state,lease_owner FROM ${T} WHERE id='job-000'`);\n ok(\"candidate_expired_recovery_preserved\",recovered.rows[0]?.state===\"READY\" && recovered.rows[0]?.lease_owner===null,{row:recovered.rows[0]});\n\n const independentStill:any=await ex(`SELECT count(*) AS n FROM ${T} WHERE state='LEASED' AND lease_owner LIKE 'independent-%'`);\n ok(\"recovery_does_not_clear_live_other_workers\",Number(independentStill.rows[0]?.n)===16,{count:independentStill.rows[0]?.n});\n\n out.summary={passed:out.tests.filter((x:any)=>x.ok).length,failed:out.failures.length,total:out.tests.length};\n console.log(JSON.stringify(out,null,2));\n}finally{\n await sqlite.execute(`DROP TABLE IF EXISTS ${T}`);\n}\nif(out.failures.length)throw new Error(\"STRESS_FAILURE:\"+out.failures.join(\",\"));\n",[],[147,453],"3de48ab6-15f3-4ef7-a53a-cce0c3688f47","brain_bridge_worker_v3_candidate_test.ts","01a07b80-b4d6-73c0-ae85-5b864893fa11",["D",1788791971867],"import { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\nimport { activeLeaseDecision, activeLeaseSql, leaseOneSql, normalizeDispatch, recoverExpiredSql, resultSql } from \"./brain_bridge_worker_v3_candidate.ts\";\n\nconst T=\"brain_bridge_jobs_v3_test_4d71\";\nconst out:any={tests:[],failures:[]};\nfunction ok(name:string,cond:boolean,detail:any={}) {\n out.tests.push({name,ok:!!cond,detail});\n if(!cond) out.failures.push(name);\n}\nasync function ex(sql:string,args:any[]=[]){return await sqlite.execute({sql,args});}\n\nawait sqlite.execute(`DROP TABLE IF EXISTS ${T}`);\nawait sqlite.execute(`CREATE TABLE ${T}(\n id TEXT PRIMARY KEY, priority REAL NOT NULL DEFAULT 0, op TEXT NOT NULL, payload_json TEXT NOT NULL,\n state TEXT NOT NULL DEFAULT 'READY', lease_owner TEXT, lease_expires_at TEXT,\n result_json TEXT,error_json TEXT,created_at TEXT NOT NULL,updated_at TEXT NOT NULL)`);\ntry {\n const payload=JSON.stringify({args:[\"status\"],timeout:60});\n await ex(`INSERT INTO ${T}(id,priority,op,payload_json,state,created_at,updated_at) VALUES\n ('job-a',20,'brain',?,'READY','2026-01-01 00:00:00','2026-01-01 00:00:00'),\n ('job-b',20,'brain',?,'READY','2026-01-01 00:00:00','2026-01-01 00:00:00'),\n ('job-c',10,'brain',?,'READY','2026-01-01 00:00:00','2026-01-01 00:00:00')`,[payload,payload,payload]);\n\n const [p1,p2]:any[]=await Promise.all([\n ex(leaseOneSql(T),[\"worker-same\",\"worker-same\"]),\n ex(leaseOneSql(T),[\"worker-same\",\"worker-same\"])\n ]);\n const got=[...(p1.rows||[]),...(p2.rows||[])];\n ok(\"single_flight_concurrent_same_worker\",got.length===1,{leased:got.map((x:any)=>x.id)});\n ok(\"deterministic_first_job\",got[0]?.id===\"job-a\",{id:got[0]?.id});\n\n const act:any=await ex(activeLeaseSql(T),[\"worker-same\"]);\n ok(\"exactly_one_active_lease\",act.rows?.length===1,{rows:act.rows});\n const busy=activeLeaseDecision(act.rows||[]);\n ok(\"active_lease_not_redelivered\",busy.kind===\"busy\" && busy.active_job_id===\"job-a\",busy);\n ok(\"free_worker_decision\",activeLeaseDecision([]).kind===\"free\");\n\n const other:any=await ex(leaseOneSql(T),[\"worker-other\",\"worker-other\"]);\n ok(\"different_worker_can_lease\",other.rows?.length===1 && other.rows[0].id===\"job-b\",{rows:other.rows});\n\n await ex(`UPDATE ${T} SET lease_expires_at=datetime('now','-1 second') WHERE id='job-a'`);\n await sqlite.execute(recoverExpiredSql(T));\n const state:any=await ex(`SELECT state,lease_owner,lease_expires_at FROM ${T} WHERE id='job-a'`);\n ok(\"expired_lease_recovered\",state.rows?.[0]?.state===\"READY\" && state.rows[0].lease_owner===null && state.rows[0].lease_expires_at===null,{row:state.rows?.[0]});\n const rel:any=await ex(leaseOneSql(T),[\"worker-same\",\"worker-same\"]);\n ok(\"recovered_job_releasable\",rel.rows?.[0]?.id===\"job-a\",{rows:rel.rows});\n\n const boot=normalizeDispatch(\"brain\",JSON.stringify({args:[\"boot\",\"--id\",\"a\"],timeout:60}));\n ok(\"boot_alias_normalized\",boot.ok && JSON.parse(boot.payload_json).args[0]===\"boot-agent\",boot);\n\n const unchanged=normalizeDispatch(\"brain\",JSON.stringify({args:[\"status\"],timeout:60}));\n ok(\"normal_brain_command_unchanged\",unchanged.ok && JSON.parse(unchanged.payload_json).args[0]===\"status\",unchanged);\n\n const rt=normalizeDispatch(\"read_text\",JSON.stringify({path:\"/brain/artifacts/x.txt\",max_bytes:200000}));\n ok(\"read_text_allowed_artifact\",rt.ok,rt);\n ok(\"read_text_join_allowed\",normalizeDispatch(\"read_text\",JSON.stringify({path:\"/brain/JOIN_PROTOCOL.md\",max_bytes:1})).ok);\n ok(\"read_text_traversal_rejected\",!normalizeDispatch(\"read_text\",JSON.stringify({path:\"/brain/artifacts/../brain.db\",max_bytes:10})).ok);\n ok(\"read_text_backslash_rejected\",!normalizeDispatch(\"read_text\",JSON.stringify({path:\"/brain/artifacts/x\\\\y\",max_bytes:10})).ok);\n ok(\"read_text_directory_rejected\",!normalizeDispatch(\"read_text\",JSON.stringify({path:\"/brain/artifacts/\",max_bytes:10})).ok);\n ok(\"read_text_outside_rejected\",!normalizeDispatch(\"read_text\",JSON.stringify({path:\"/etc/passwd\",max_bytes:10})).ok);\n ok(\"read_text_oversize_rejected\",!normalizeDispatch(\"read_text\",JSON.stringify({path:\"/brain/artifacts/x\",max_bytes:200001})).ok);\n ok(\"unsupported_op_rejected\",!normalizeDispatch(\"exec\",JSON.stringify({})).ok);\n\n // Expired results cannot complete a job.\n await ex(`UPDATE ${T} SET state='LEASED',lease_owner='worker-late',lease_expires_at=datetime('now','-1 second') WHERE id='job-c'`);\n const late:any=await ex(resultSql(T),[\"COMPLETE\",\"{}\",\"\", \"job-c\",\"worker-late\"]);\n ok(\"expired_result_rejected\",(late.rows?.length||0)===0,{rows:late.rows});\n await sqlite.execute(recoverExpiredSql(T));\n const lateState:any=await ex(`SELECT state FROM ${T} WHERE id='job-c'`);\n ok(\"expired_result_job_recoverable\",lateState.rows?.[0]?.state===\"READY\",{row:lateState.rows?.[0]});\n\n // Existing multi-lease state is detectable by the active query.\n await ex(`UPDATE ${T} SET state='LEASED',lease_owner='worker-bad',lease_expires_at=datetime('now','+60 seconds') WHERE id IN ('job-a','job-b')`);\n const multi:any=await ex(activeLeaseSql(T),[\"worker-bad\"]);\n ok(\"preexisting_multi_lease_detectable\",(multi.rows?.length||0)===2,{count:multi.rows?.length});\n ok(\"preexisting_multi_lease_fail_closed\",activeLeaseDecision(multi.rows||[]).kind===\"conflict\",activeLeaseDecision(multi.rows||[]));\n\n out.summary={passed:out.tests.filter((x:any)=>x.ok).length,failed:out.failures.length,total:out.tests.length};\n console.log(JSON.stringify(out,null,2));\n} finally {\n await sqlite.execute(`DROP TABLE IF EXISTS ${T}`);\n}\nif(out.failures.length) throw new Error(\"TEST_FAILURE:\"+out.failures.join(\",\"));\n",[],[147,460],"94b5e00d-7cbf-41cf-a7b9-7b1f6543ca89","brain_bridge_worker_v3_candidate.ts","01a07b80-b4d6-73c0-ae85-56de2c12bcea",["D",1788791971867],"import { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\n\nconst WORKER_TOKEN = Deno.env.get(\"BRAIN_BRIDGE_WORKER_TOKEN\") || \"\";\nconst JOB_TABLE = \"brain_bridge_jobs\";\nexport const MAX_READ_BYTES = 200_000;\n\nfunction tableName(table: string): string {\n if (!/^[A-Za-z_][A-Za-z0-9_]*$/.test(table)) throw new Error(\"BAD_TABLE\");\n return table;\n}\n\nexport function recoverExpiredSql(table = JOB_TABLE): string {\n table = tableName(table);\n return `UPDATE ${table}\n SET state='READY',lease_owner=NULL,lease_expires_at=NULL,updated_at=datetime('now')\n WHERE state='LEASED'\n AND lease_expires_at IS NOT NULL\n AND lease_expires_at <= datetime('now')`;\n}\n\nexport function activeLeaseSql(table = JOB_TABLE): string {\n table = tableName(table);\n return `SELECT id,op,payload_json,priority,lease_expires_at\n FROM ${table}\n WHERE state='LEASED'\n AND lease_owner=?\n AND lease_expires_at > datetime('now')\n ORDER BY updated_at,id`;\n}\n\nexport function leaseOneSql(table = JOB_TABLE): string {\n table = tableName(table);\n return `UPDATE ${table}\n SET state='LEASED',lease_owner=?,lease_expires_at=datetime('now','+90 seconds'),updated_at=datetime('now')\n WHERE id=(\n SELECT j.id\n FROM ${table} j\n WHERE j.state='READY'\n AND NOT EXISTS (\n SELECT 1 FROM ${table} x\n WHERE x.state='LEASED'\n AND x.lease_owner=?\n AND x.lease_expires_at > datetime('now')\n )\n ORDER BY j.priority DESC,j.created_at,j.id\n LIMIT 1\n )\n RETURNING id,op,payload_json,priority,lease_expires_at`;\n}\n\nexport function resultSql(table = JOB_TABLE): string {\n table = tableName(table);\n return `UPDATE ${table}\n SET state=?,result_json=?,error_json=?,lease_expires_at=NULL,updated_at=datetime('now')\n WHERE id=?\n AND state='LEASED'\n AND lease_owner=?\n AND lease_expires_at > datetime('now')\n RETURNING id,state`;\n}\n\nexport type DispatchResult =\n | {ok:true; payload_json:string; alias?:string}\n | {ok:false; error:string};\n\nexport function normalizeDispatch(op: string, payloadJson: string): DispatchResult {\n let q:any;\n try { q=JSON.parse(payloadJson); }\n catch { return {ok:false,error:\"PAYLOAD_JSON_INVALID\"}; }\n if (!q || typeof q !== \"object\" || Array.isArray(q)) return {ok:false,error:\"PAYLOAD_OBJECT_REQUIRED\"};\n\n if (op === \"brain\") {\n if (!Array.isArray(q.args) || q.args.length < 1 || q.args.some((x:any)=>typeof x !== \"string\")) {\n return {ok:false,error:\"BRAIN_ARGS_INVALID\"};\n }\n const out=structuredClone(q);\n if (out.args[0] === \"boot\") {\n out.args[0] = \"boot-agent\";\n return {ok:true,payload_json:JSON.stringify(out),alias:\"boot->boot-agent\"};\n }\n return {ok:true,payload_json:JSON.stringify(out)};\n }\n\n if (op === \"read_text\") {\n const keys=Object.keys(q).sort();\n if (keys.some(k=>k!==\"path\" && k!==\"max_bytes\")) return {ok:false,error:\"READ_TEXT_SCHEMA_NOT_CLOSED\"};\n if (typeof q.path !== \"string\") return {ok:false,error:\"READ_TEXT_PATH_REQUIRED\"};\n if (q.path.includes(\"\\0\") || q.path.includes(\"\\\\\") || q.path.split(\"/\").some((s:string)=>s===\".\" || s===\"..\")) {\n return {ok:false,error:\"READ_TEXT_TRAVERSAL_REJECTED\"};\n }\n const artifactFile=q.path.startsWith(\"/brain/artifacts/\") && q.path.length>\"/brain/artifacts/\".length && !q.path.endsWith(\"/\");\n if (!(q.path === \"/brain/JOIN_PROTOCOL.md\" || artifactFile)) {\n return {ok:false,error:\"READ_TEXT_PATH_FORBIDDEN\"};\n }\n if (!Number.isInteger(q.max_bytes) || q.max_bytes < 1 || q.max_bytes > MAX_READ_BYTES) {\n return {ok:false,error:\"READ_TEXT_MAX_BYTES_INVALID\"};\n }\n return {ok:true,payload_json:JSON.stringify({path:q.path,max_bytes:q.max_bytes})};\n }\n\n return {ok:false,error:\"OP_UNSUPPORTED\"};\n}\n\nasync function rejectInvalidLease(worker:string,id:string,error:string) {\n await sqlite.execute({\n sql:`UPDATE ${JOB_TABLE}\n SET state='FAILED',result_json=NULL,error_json=?,lease_expires_at=NULL,updated_at=datetime('now')\n WHERE id=? AND state='LEASED' AND lease_owner=?`,\n args:[JSON.stringify({classification:\"BRIDGE_DISPATCH_REJECTED\",error}),id,worker]\n });\n}\n\nasync function dispatchRow(worker:string,row:any) {\n const n=normalizeDispatch(String(row.op),String(row.payload_json));\n if (!n.ok) {\n await rejectInvalidLease(worker,String(row.id),n.error);\n return {ok:true,job:null,rejected_job:String(row.id),dispatch_error:n.error};\n }\n return {ok:true,job:{...row,payload_json:n.payload_json},reused:false,alias:n.alias||null};\n}\n\nexport function activeLeaseDecision(rows:any[]) {\n if (rows.length > 1) return {kind:\"conflict\" as const,count:rows.length};\n if (rows[0]) return {\n kind:\"busy\" as const,\n active_job_id:String(rows[0].id),\n lease_expires_at:rows[0].lease_expires_at\n };\n return {kind:\"free\" as const};\n}\n\nasync function poll(worker:string) {\n await sqlite.execute(recoverExpiredSql());\n\n const active:any=await sqlite.execute({sql:activeLeaseSql(),args:[worker]});\n const before=activeLeaseDecision(active.rows||[]);\n if (before.kind===\"conflict\") {\n return Response.json({ok:false,error:\"MULTIPLE_ACTIVE_LEASES\",worker_id:worker,count:before.count},{status:409});\n }\n if (before.kind===\"busy\") {\n // Never redeliver an unexpired lease to another process sharing the same worker_id.\n // With no per-process nonce, waiting for expiry is the only fail-closed way to avoid duplicate execution.\n return Response.json({ok:true,job:null,busy:true,active_job_id:before.active_job_id,lease_expires_at:before.lease_expires_at});\n }\n\n const leased:any=await sqlite.execute({sql:leaseOneSql(),args:[worker,worker]});\n if (leased.rows?.[0]) {\n const out:any=await dispatchRow(worker,leased.rows[0]);\n return Response.json(out);\n }\n\n // A concurrent poll by the same worker may have won between the active check and atomic lease.\n const after:any=await sqlite.execute({sql:activeLeaseSql(),args:[worker]});\n const raced=activeLeaseDecision(after.rows||[]);\n if (raced.kind===\"conflict\") {\n return Response.json({ok:false,error:\"MULTIPLE_ACTIVE_LEASES\",worker_id:worker,count:raced.count},{status:409});\n }\n if (raced.kind===\"busy\") {\n return Response.json({ok:true,job:null,busy:true,active_job_id:raced.active_job_id,lease_expires_at:raced.lease_expires_at});\n }\n return Response.json({ok:true,job:null,busy:false});\n}\n\nexport default async function(req: Request): Promise {\n const u = new URL(req.url);\n if (req.method === \"GET\" && u.pathname.endsWith(\"/health\")) {\n return Response.json({\n ok:true,\n service:\"brain-bridge-worker-v3-candidate\",\n endpoint_live:true,\n worker_process_live:\"UNATTESTED_BY_ENDPOINT\",\n single_flight:true,\n boot_alias:\"boot->boot-agent\",\n read_text_max_bytes:MAX_READ_BYTES\n });\n }\n if (req.method !== \"POST\") return Response.json({ok:false,error:\"METHOD\"},{status:405});\n const supplied=req.headers.get(\"x-brain-worker-token\") || \"\";\n if (!WORKER_TOKEN || supplied !== WORKER_TOKEN) {\n return Response.json({ok:false,error:\"UNAUTHORIZED\"},{status:401});\n }\n let q:any;\n try { q=await req.json(); }\n catch { return Response.json({ok:false,error:\"BAD_JSON\"},{status:400}); }\n\n if (u.pathname.endsWith(\"/poll\")) {\n const worker=String(q.worker_id || \"\");\n if (!worker || worker.length>128) return Response.json({ok:false,error:\"WORKER_REQUIRED\"},{status:400});\n return await poll(worker);\n }\n\n if (u.pathname.endsWith(\"/result\")) {\n const worker=String(q.worker_id || \"\");\n const id=String(q.id || \"\");\n const success=q.success===true;\n if (!worker || !id) return Response.json({ok:false,error:\"BAD_RESULT_ID\"},{status:400});\n const r:any=await sqlite.execute({\n sql:resultSql(),\n args:[success?\"COMPLETE\":\"FAILED\",success?JSON.stringify(q.result??null):null,success?null:JSON.stringify(q.error??null),id,worker]\n });\n if (!r.rows?.length) return Response.json({ok:false,error:\"LEASE_MISMATCH_OR_EXPIRED\"},{status:409});\n return Response.json({ok:true,id,state:r.rows[0].state});\n }\n return Response.json({ok:false,error:\"NOT_FOUND\"},{status:404});\n}\n",[],[147,467],"7e105326-ce99-4116-ad6d-ffdf545f8683","brain_bridge_worker.ts","01a07b80-b4d6-73c0-ae85-5f5e10871459",["D",1788791971867],"import { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\n\nconst WORKER_TOKEN = Deno.env.get(\"BRAIN_BRIDGE_WORKER_TOKEN\") || \"\";\nconst JOB_TABLE = \"brain_bridge_jobs\";\nconst WORKER_TABLE = \"brain_bridge_workers_v6\";\nconst EXPECTED_WORKER_ID = \"project-brain-live-v1-worker-v2\";\nexport const STALE_SECONDS = 90;\nexport const DEAD_SECONDS = 180;\nexport const PRIORITY_CAP = 1_000_000_000;\nexport const MAX_JOB_TIMEOUT = 120;\nexport const LEASE_SECONDS = 180;\nexport const MAX_READ_BYTES = 200_000;\n\nexport const SUPPORTED_BRAIN_COMMANDS = [\n \"status\",\n \"verify-chain\",\n \"verify-claim-graph\",\n \"register-agent\",\n \"ensure-task\",\n \"delegate-task\",\n \"claim\",\n \"renew-lease\",\n \"commit\",\n \"checkpoint\",\n \"add-claim\",\n \"invalidate-claim\",\n \"supersede-task-context\",\n \"migrate-task-invariants\",\n \"reconcile-causal-blocks\",\n \"recover-stale\"\n] as const;\nconst SUPPORTED = new Set(SUPPORTED_BRAIN_COMMANDS);\n\nfunction json(v:unknown,status=200){return Response.json(v,{status});}\nfunction tableName(table:string){if(!/^[A-Za-z_][A-Za-z0-9_]*$/.test(table))throw new Error(\"BAD_TABLE\");return table;}\n\nexport function classifyWorkerAge(ageSeconds:number|null){\n if(ageSeconds===null || !Number.isFinite(ageSeconds)) return {state:\"UNKNOWN\",reason:\"NO_WORKER_HEARTBEAT\"};\n if(ageSeconds<=STALE_SECONDS) return {state:\"HEALTHY\",reason:\"RECENT_WORKER_POLL\"};\n if(ageSeconds<=DEAD_SECONDS) return {state:\"DEGRADED\",reason:\"WORKER_POLL_STALE\"};\n return {state:\"DOWN\",reason:\"WORKER_POLL_DEAD\"};\n}\nexport function effectivePriority(x:number){if(!Number.isFinite(x))return 0;return Math.min(x,PRIORITY_CAP);}\nexport function healthHttpStatus(workerState:string,duplicateActiveLeases:number,expiredLeases:number,legacyUnattestedActiveLeases=0,recentInstanceCount=1){\n return workerState===\"HEALTHY\" && duplicateActiveLeases===0 && expiredLeases===0 && legacyUnattestedActiveLeases===0 && recentInstanceCount===1 ? 200 : 503;\n}\nexport function legacyLeaseRiskLeases(leasedCount:number,legacyRiskCount:number){\n return legacyRiskCount>0 && leasedCount>0 ? leasedCount : 0;\n}\nexport function activeLeaseDecision(rows:any[]){\n if(rows.length>1)return {kind:\"conflict\" as const,count:rows.length};\n if(rows[0])return {kind:\"busy\" as const,active_job_id:String(rows[0].id),lease_expires_at:rows[0].lease_expires_at};\n return {kind:\"free\" as const};\n}\n\nexport function recoverExpiredSql(table=JOB_TABLE){\n table=tableName(table);\n return `UPDATE ${table}\n SET state='READY',lease_owner=NULL,lease_expires_at=NULL,updated_at=datetime('now')\n WHERE state='LEASED' AND lease_expires_at IS NOT NULL AND lease_expires_at <= datetime('now')`;\n}\nexport function activeLeaseSql(table=JOB_TABLE){\n table=tableName(table);\n return `SELECT id,op,payload_json,priority,lease_expires_at\n FROM ${table}\n WHERE state='LEASED' AND lease_owner=? AND lease_expires_at > datetime('now')\n ORDER BY lease_expires_at,id LIMIT 2`;\n}\nexport function isAttestedInstance(instance:string){return !!instance && instance!==\"LEGACY_UNATTESTED_INSTANCE\";}\nfunction exactRecoverPredicate(alias=\"j\"){\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]')='recover-stale'\n AND json_type(${alias}.payload_json,'$.timeout')='integer'\n AND json_extract(${alias}.payload_json,'$.timeout') BETWEEN 1 AND ${MAX_JOB_TIMEOUT}\n AND (SELECT COUNT(*) FROM json_each(${alias}.payload_json))=2)`;\n}\nexport function leaseOneSql(table=JOB_TABLE,allowRecovery=true){\n table=tableName(table);\n const recover=exactRecoverPredicate(\"j\");\n const recoveryEligibility=allowRecovery ? \"1=1\" : `NOT ${recover}`;\n const recoveryOrder=allowRecovery ? `CASE WHEN ${recover} THEN 0 ELSE 1 END` : \"1\";\n return `UPDATE ${table}\n SET state='LEASED',lease_owner=?,lease_expires_at=datetime('now','+${LEASE_SECONDS} seconds'),updated_at=datetime('now')\n WHERE id=(\n SELECT j.id FROM ${table} j\n WHERE j.state='READY'\n AND (${recoveryEligibility})\n AND NOT EXISTS(\n SELECT 1 FROM ${table} x\n WHERE x.state='LEASED' AND x.lease_owner=? AND x.lease_expires_at > datetime('now')\n )\n ORDER BY\n ${recoveryOrder} ASC,\n CASE WHEN j.priority > ${PRIORITY_CAP} THEN ${PRIORITY_CAP} 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`;\n}\nexport function resultSql(table=JOB_TABLE){\n table=tableName(table);\n return `UPDATE ${table}\n SET state=?,result_json=?,error_json=?,lease_expires_at=NULL,updated_at=datetime('now')\n WHERE id=? AND state='LEASED' AND lease_owner=? AND lease_expires_at > datetime('now')\n RETURNING id,state`;\n}\n\nexport type DispatchResult=\n | {ok:true;payload_json:string}\n | {ok:false;error:string};\n\nfunction exactKeys(q:any, expected:string[]){\n const got=Object.keys(q).sort();\n const want=[...expected].sort();\n return got.length===want.length && got.every((k,i)=>k===want[i]);\n}\n\nexport function normalizeDispatch(op:string,payloadJson:string):DispatchResult{\n let q:any;try{q=JSON.parse(payloadJson)}catch{return {ok:false,error:\"PAYLOAD_JSON_INVALID\"}}\n if(!q || typeof q!==\"object\" || Array.isArray(q))return {ok:false,error:\"PAYLOAD_OBJECT_REQUIRED\"};\n\n if(op===\"brain\"){\n if(!exactKeys(q,[\"args\",\"timeout\"]))return {ok:false,error:\"BRAIN_PAYLOAD_SCHEMA_NOT_CLOSED\"};\n if(!Array.isArray(q.args) || q.args.length<1 || q.args.some((x:any)=>typeof x!==\"string\"))return {ok:false,error:\"BRAIN_ARGS_INVALID\"};\n if(!Number.isInteger(q.timeout) || q.timeout<1 || q.timeout>MAX_JOB_TIMEOUT)return {ok:false,error:\"BRAIN_TIMEOUT_INVALID\"};\n const cmd=q.args[0];\n if(cmd===\"boot\")return {ok:false,error:\"BOOT_NOT_ATOMIC_USE_REGISTER_AGENT_THEN_CLAIM\"};\n if(cmd===\"boot-agent\")return {ok:false,error:\"RAW_BOOT_AGENT_NOT_BRIDGE_COMMAND\"};\n if(cmd===\"recover-leases\")return {ok:false,error:\"RECOVER_LEASE_ALIAS_NOT_AVAILABLE_ON_CURRENT_EXECUTOR\"};\n if(!SUPPORTED.has(cmd))return {ok:false,error:\"BRAIN_SUBCOMMAND_NOT_ALLOWED\"};\n return {ok:true,payload_json:JSON.stringify({args:q.args,timeout:q.timeout})};\n }\n\n if(op===\"read_text\"){\n if(!exactKeys(q,[\"path\",\"max_bytes\"]))return {ok:false,error:\"READ_TEXT_SCHEMA_NOT_CLOSED\"};\n if(typeof q.path!==\"string\")return {ok:false,error:\"READ_TEXT_PATH_REQUIRED\"};\n if(q.path.includes(\"\\0\") || q.path.includes(\"\\\\\") || q.path.split(\"/\").some((s:string)=>s===\".\" || s===\"..\")){\n return {ok:false,error:\"READ_TEXT_TRAVERSAL_REJECTED\"};\n }\n const artifactFile=q.path.startsWith(\"/brain/artifacts/\") && q.path.length>\"/brain/artifacts/\".length && !q.path.endsWith(\"/\");\n if(!(q.path===\"/brain/JOIN_PROTOCOL.md\" || artifactFile))return {ok:false,error:\"READ_TEXT_PATH_FORBIDDEN\"};\n if(!Number.isInteger(q.max_bytes) || q.max_bytes<1 || q.max_bytes>MAX_READ_BYTES)return {ok:false,error:\"READ_TEXT_MAX_BYTES_INVALID\"};\n return {ok:true,payload_json:JSON.stringify({path:q.path,max_bytes:q.max_bytes})};\n }\n return {ok:false,error:\"OP_UNSUPPORTED\"};\n}\n\nasync function ensureTables(){\n await sqlite.execute(`CREATE TABLE IF NOT EXISTS ${WORKER_TABLE} (\n endpoint_host TEXT NOT NULL,\n worker_id TEXT NOT NULL,\n instance_id TEXT NOT NULL,\n first_seen_at TEXT NOT NULL,\n last_poll_at TEXT,\n last_result_at TEXT,\n lease_count INTEGER NOT NULL DEFAULT 0,\n result_count INTEGER NOT NULL DEFAULT 0,\n updated_at TEXT NOT NULL,\n PRIMARY KEY(endpoint_host,worker_id,instance_id)\n )`);\n}\nfunction instanceOf(q:any){const v=String(q?.instance_id||\"\").trim();return v||\"LEGACY_UNATTESTED_INSTANCE\";}\nexport function endpointScope(req:Request){return new URL(req.url).host.toLowerCase();}\n\nasync function workerHealth(endpointHost:string){\n await ensureTables();\n const wr:any=await sqlite.execute({\n sql:`SELECT worker_id,instance_id,last_poll_at,last_result_at,lease_count,result_count,\n CAST((julianday('now')-julianday(last_poll_at))*86400 AS INTEGER) AS poll_age_seconds\n FROM ${WORKER_TABLE}\n WHERE endpoint_host=? AND worker_id=?\n ORDER BY last_poll_at DESC LIMIT 1`,\n args:[endpointHost,EXPECTED_WORKER_ID]\n });\n const w=wr.rows?.[0]||null;\n const ri:any=await sqlite.execute({\n sql:`SELECT COUNT(*) AS recent_instance_count\n FROM ${WORKER_TABLE}\n WHERE endpoint_host=? AND worker_id=?\n AND last_poll_at IS NOT NULL\n AND last_poll_at >= datetime('now', '-' || ? || ' seconds')`,\n args:[endpointHost,EXPECTED_WORKER_ID,STALE_SECONDS]\n });\n const recentInstanceCount=Number(ri.rows?.[0]?.recent_instance_count||0);\n const legacyRisk:any=await sqlite.execute({\n sql:`SELECT COUNT(*) AS legacy_risk_count\n FROM ${WORKER_TABLE}\n WHERE endpoint_host=? AND worker_id=?\n AND instance_id='LEGACY_UNATTESTED_INSTANCE'\n AND last_poll_at IS NOT NULL\n AND last_poll_at >= datetime('now', '-' || ? || ' seconds')`,\n args:[endpointHost,EXPECTED_WORKER_ID,LEASE_SECONDS]\n });\n const legacyRiskCount=Number(legacyRisk.rows?.[0]?.legacy_risk_count||0);\n const qc:any=await sqlite.execute({\n sql:`SELECT\n SUM(CASE WHEN state='READY' THEN 1 ELSE 0 END) AS ready_count,\n SUM(CASE WHEN state='LEASED' THEN 1 ELSE 0 END) AS leased_count,\n SUM(CASE WHEN state='LEASED' AND lease_expires_at <= datetime('now') THEN 1 ELSE 0 END) AS expired_lease_count,\n SUM(CASE WHEN state='READY' AND priority > ? THEN 1 ELSE 0 END) AS overcap_ready_count,\n MIN(CASE WHEN state='READY' THEN created_at END) AS oldest_ready_at,\n MIN(CASE WHEN state='LEASED' THEN lease_expires_at END) AS earliest_lease_expiry\n FROM brain_bridge_jobs`,\n args:[PRIORITY_CAP]\n });\n const dup:any=await sqlite.execute(`\n SELECT COUNT(*) AS duplicate_worker_count FROM (\n SELECT lease_owner FROM brain_bridge_jobs\n WHERE state='LEASED' AND lease_expires_at > datetime('now') AND lease_owner IS NOT NULL\n GROUP BY lease_owner HAVING COUNT(*) > 1\n )`);\n const q=qc.rows?.[0]||{};\n const duplicateActiveLeases=Number(dup.rows?.[0]?.duplicate_worker_count||0);\n const cls=classifyWorkerAge(w?Number(w.poll_age_seconds):null);\n const expiredLeases=Number(q.expired_lease_count||0);\n const leasedCount=Number(q.leased_count||0);\n const expectedWorkerLeases:any=await sqlite.execute({\n sql:`SELECT COUNT(*) AS active_lease_count\n FROM ${JOB_TABLE}\n WHERE state='LEASED' AND lease_owner=? AND lease_expires_at > datetime('now')`,\n args:[EXPECTED_WORKER_ID]\n });\n const expectedWorkerActiveLeaseCount=Number(expectedWorkerLeases.rows?.[0]?.active_lease_count||0);\n // A legacy process can own a still-live 180s queue lease after its heartbeat has aged\n // beyond the 90s recent-instance window. Hold health closed for the full lease horizon\n // only when this expected logical worker still owns an active lease.\n const legacyUnattestedActiveLeases=legacyLeaseRiskLeases(expectedWorkerActiveLeaseCount,legacyRiskCount);\n const status=healthHttpStatus(cls.state,duplicateActiveLeases,expiredLeases,legacyUnattestedActiveLeases,recentInstanceCount);\n return {status,body:{\n endpoint_ok:true,\n service:\"brain-bridge-worker-v5-rebased-candidate\",\n worker:w,\n worker_state:cls.state,\n worker_reason:cls.reason,\n instance_identity_available:w ? w.instance_id!==\"LEGACY_UNATTESTED_INSTANCE\" : false,\n duplicate_active_worker_leases:duplicateActiveLeases,\n legacy_unattested_active_leases:legacyUnattestedActiveLeases,\n expected_worker_id:EXPECTED_WORKER_ID,\n recent_expected_worker_instances:recentInstanceCount,\n queue:q,\n transport_priority_cap:PRIORITY_CAP,\n max_brain_timeout_seconds:MAX_JOB_TIMEOUT,\n queue_lease_seconds:LEASE_SECONDS,\n selection_policy:\"RECOVERY_FIRST_THEN_CLAMPED_PRIORITY_FIFO_SINGLE_FLIGHT\",\n atomic_single_flight:true,\n fail_closed_http_status:status\n }};\n}\n\nasync function rejectInvalidLease(worker:string,id:string,error:string){\n await sqlite.execute({\n sql:`UPDATE ${JOB_TABLE}\n SET state='FAILED',result_json=NULL,error_json=?,lease_expires_at=NULL,updated_at=datetime('now')\n WHERE id=? AND state='LEASED' AND lease_owner=?`,\n args:[JSON.stringify({classification:\"BRIDGE_DISPATCH_REJECTED\",error}),id,worker]\n });\n}\n\nexport default async function(req:Request):Promise{\n const u=new URL(req.url);\n const endpointHost=endpointScope(req);\n if(req.method===\"GET\" && u.pathname.endsWith(\"/health\")){\n const h=await workerHealth(endpointHost);return json(h.body,h.status);\n }\n if(req.method!==\"POST\")return json({ok:false,error:\"METHOD\"},405);\n const supplied=req.headers.get(\"x-brain-worker-token\")||\"\";\n if(!WORKER_TOKEN || supplied!==WORKER_TOKEN)return json({ok:false,error:\"UNAUTHORIZED\"},401);\n let q:any;try{q=await req.json()}catch{return json({ok:false,error:\"BAD_JSON\"},400)}\n await ensureTables();\n\n if(u.pathname.endsWith(\"/poll\")){\n const worker=String(q.worker_id||\"\").trim();\n if(!worker || worker.length>128)return json({ok:false,error:\"WORKER_REQUIRED\"},400);\n if(worker!==EXPECTED_WORKER_ID)return json({ok:false,error:\"WORKER_ID_MISMATCH\"},403);\n const instance=instanceOf(q);\n await sqlite.execute({\n sql:`INSERT INTO ${WORKER_TABLE}(endpoint_host,worker_id,instance_id,first_seen_at,last_poll_at,updated_at)\n VALUES(?,?,?,datetime('now'),datetime('now'),datetime('now'))\n ON CONFLICT(endpoint_host,worker_id,instance_id) DO UPDATE SET last_poll_at=datetime('now'),updated_at=datetime('now')`,\n args:[endpointHost,worker,instance]\n });\n\n await sqlite.execute(recoverExpiredSql());\n const ar:any=await sqlite.execute({sql:activeLeaseSql(),args:[worker]});\n const before=activeLeaseDecision(ar.rows||[]);\n if(before.kind===\"conflict\")return json({ok:false,error:\"MULTIPLE_ACTIVE_LEASES\",worker_id:worker,count:before.count},409);\n if(before.kind===\"busy\")return json({ok:true,job:null,reason:\"ACTIVE_LEASE_EXISTS\",active_lease:{id:before.active_job_id,lease_expires_at:before.lease_expires_at},worker_id:worker,instance_id:instance});\n\n const r:any=await sqlite.execute({sql:leaseOneSql(JOB_TABLE,isAttestedInstance(instance)),args:[worker,worker]});\n if(!r.rows?.[0]){\n return json({ok:true,job:null,reason:\"NO_READY_JOB_OR_RACED_ACTIVE_LEASE\",worker_id:worker,instance_id:instance,priority_cap:PRIORITY_CAP});\n }\n\n const row=r.rows[0];\n const normalized=normalizeDispatch(String(row.op),String(row.payload_json));\n if(!normalized.ok){\n await rejectInvalidLease(worker,String(row.id),normalized.error);\n return json({ok:true,job:null,reason:\"DISPATCH_REJECTED\",rejected_job:String(row.id),dispatch_error:normalized.error,worker_id:worker,instance_id:instance});\n }\n\n await sqlite.execute({\n sql:`UPDATE ${WORKER_TABLE} SET lease_count=lease_count+1,updated_at=datetime('now') WHERE endpoint_host=? AND worker_id=? AND instance_id=?`,\n args:[endpointHost,worker,instance]\n });\n return json({ok:true,job:{...row,payload_json:normalized.payload_json},worker_id:worker,instance_id:instance,priority_cap:PRIORITY_CAP,lease_seconds:LEASE_SECONDS});\n }\n\n if(u.pathname.endsWith(\"/result\")){\n const worker=String(q.worker_id||\"\").trim(),id=String(q.id||\"\").trim(),success=q.success===true;\n const instance=instanceOf(q);\n if(!worker||!id)return json({ok:false,error:\"BAD_RESULT_ID\"},400);\n if(worker!==EXPECTED_WORKER_ID)return json({ok:false,error:\"WORKER_ID_MISMATCH\"},403);\n const r:any=await sqlite.execute({\n sql:resultSql(),\n args:[success?\"COMPLETE\":\"FAILED\",success?JSON.stringify(q.result??null):null,success?null:JSON.stringify(q.error??null),id,worker]\n });\n if(!r.rows?.length)return json({ok:false,error:\"LEASE_MISMATCH_OR_EXPIRED\"},409);\n await sqlite.execute({\n sql:`UPDATE ${WORKER_TABLE} SET last_result_at=datetime('now'),result_count=result_count+1,updated_at=datetime('now') WHERE endpoint_host=? AND worker_id=? AND instance_id=?`,\n args:[endpointHost,worker,instance]\n });\n return json({ok:true,id,state:r.rows[0].state,worker_id:worker,instance_id:instance});\n }\n return json({ok:false,error:\"NOT_FOUND\"},404);\n}\n",[],[147,474],"862c6095-b186-4a25-ae2e-369e266b3e9a","brain_bridge_recovery_first_test_0120.ts","01a07b80-b4d6-73c0-ae85-627ea0baff5f",["D",1788791971867],"import { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\nimport { leaseOneSql } from \"./brain_bridge_worker.ts\";\n\nconst T=\"brain_bridge_recovery_first_test_0120\";\nconst out:any={tests:[],failures:[]};\nconst ok=(name:string,cond:boolean,detail:any={})=>{out.tests.push({name,ok:!!cond,detail});if(!cond)out.failures.push(name)};\nconst ex=(sql:string,args:any[]=[])=>sqlite.execute({sql,args});\n\nawait sqlite.execute(`DROP TABLE IF EXISTS ${T}`);\nawait sqlite.execute(`CREATE TABLE ${T}(\n id TEXT PRIMARY KEY,\n priority REAL NOT NULL DEFAULT 0,\n op TEXT NOT NULL,\n payload_json TEXT NOT NULL,\n state TEXT NOT NULL DEFAULT 'READY',\n lease_owner TEXT,\n lease_expires_at TEXT,\n result_json TEXT,\n error_json TEXT,\n created_at TEXT NOT NULL,\n updated_at TEXT NOT NULL\n)`);\n\ntry{\n const ordinary=JSON.stringify({args:[\"status\"],timeout:60});\n const recover=JSON.stringify({args:[\"recover-stale\"],timeout:60});\n const recoverExtraArg=JSON.stringify({args:[\"recover-stale\",\"oops\"],timeout:60});\n const recoverExtraKey=JSON.stringify({args:[\"recover-stale\"],timeout:60,extra:true});\n const recoverBadTimeout=JSON.stringify({args:[\"recover-stale\"],timeout:121});\n const oldAlias=JSON.stringify({args:[\"recover-leases\"],timeout:60});\n\n await ex(`INSERT INTO ${T}(id,priority,op,payload_json,state,created_at,updated_at) VALUES\n ('ordinary-old',1e300,'brain',?,'READY','2026-01-01 00:00:00','2026-01-01 00:00:00'),\n ('recover-valid',1e300,'brain',?,'READY','2026-01-01 00:00:10','2026-01-01 00:00:10')`,[ordinary,recover]);\n let r:any=await ex(leaseOneSql(T),[\"w\",\"w\"]);\n ok(\"valid_recover_preempts_older_overcap_ordinary\",r.rows?.[0]?.id===\"recover-valid\",{row:r.rows?.[0]});\n await ex(`UPDATE ${T} SET state='READY',lease_owner=NULL,lease_expires_at=NULL WHERE id='recover-valid'`);\n\n await ex(`DELETE FROM ${T}`);\n await ex(`INSERT INTO ${T}(id,priority,op,payload_json,state,created_at,updated_at) VALUES\n ('ordinary-old',1e300,'brain',?,'READY','2026-01-01 00:00:00','2026-01-01 00:00:00'),\n ('recover-extra-arg',1e300,'brain',?,'READY','2026-01-01 00:00:01','2026-01-01 00:00:01'),\n ('recover-extra-key',1e300,'brain',?,'READY','2026-01-01 00:00:02','2026-01-01 00:00:02'),\n ('recover-bad-timeout',1e300,'brain',?,'READY','2026-01-01 00:00:03','2026-01-01 00:00:03'),\n ('recover-old-alias',1e300,'brain',?,'READY','2026-01-01 00:00:04','2026-01-01 00:00:04')`,\n [ordinary,recoverExtraArg,recoverExtraKey,recoverBadTimeout,oldAlias]);\n r=await ex(leaseOneSql(T),[\"w2\",\"w2\"]);\n ok(\"invalid_recovery_shapes_do_not_preempt\",r.rows?.[0]?.id===\"ordinary-old\",{row:r.rows?.[0]});\n\n await ex(`DELETE FROM ${T}`);\n await ex(`INSERT INTO ${T}(id,priority,op,payload_json,state,created_at,updated_at) VALUES\n ('fifo-a',1e300,'brain',?,'READY','2026-01-01 00:00:00','2026-01-01 00:00:00'),\n ('fifo-b',1e300,'brain',?,'READY','2026-01-01 00:00:01','2026-01-01 00:00:01')`,[ordinary,ordinary]);\n r=await ex(leaseOneSql(T),[\"w3\",\"w3\"]);\n ok(\"ordinary_overcap_fifo_preserved\",r.rows?.[0]?.id===\"fifo-a\",{row:r.rows?.[0]});\n\n await ex(`DELETE FROM ${T}`);\n await ex(`INSERT INTO ${T}(id,priority,op,payload_json,state,created_at,updated_at,lease_owner,lease_expires_at) VALUES\n ('active',1,'brain',?,'LEASED','2026-01-01 00:00:00','2026-01-01 00:00:00','w4',datetime('now','+60 seconds')),\n ('recover-valid',1e300,'brain',?,'READY','2026-01-01 00:00:01','2026-01-01 00:00:01',NULL,NULL)`,[ordinary,recover]);\n r=await ex(leaseOneSql(T),[\"w4\",\"w4\"]);\n ok(\"single_flight_still_blocks_recovery_for_busy_same_worker\",(r.rows?.length||0)===0,{rows:r.rows});\n\n out.summary={passed:out.tests.filter((x:any)=>x.ok).length,failed:out.failures.length,total:out.tests.length};\n console.log(JSON.stringify(out,null,2));\n}finally{\n await sqlite.execute(`DROP TABLE IF EXISTS ${T}`);\n}\nif(out.failures.length) throw new Error(\"TEST_FAILURE:\"+out.failures.join(\",\"));",[],[147,481],"09e416af-fc14-454a-a076-7ae1e05d376f","README.md","01a07b80-b4d6-73c0-ae85-0b1cf2d54c40",["D",1788791971867],"# Project Brain Durable Checkpoints\n\nThis val is a non-authoritative durability domain for hash-verified Project Brain snapshots. Authority remains defined by the Brain's verified state and stronger workstream-specific authority roots.\n",[],[147,488],"2fbd8ae7-6e2a-423d-8035-548b1c6ff187","PROJECT_BRAIN_CHAT_BOOTSTRAP_V2_NO_SPRITES.md","01a07b80-b4d6-73c0-ae85-0d17644c6600",["D",1788791971867],"# PROJECT BRAIN CHAT BOOTSTRAP V3 — VAL-ONLY / NO SPRITES\n\n## Non-negotiable transport rule\n\nFor normal ChatGPT project work, do not invoke the Sprites ChatGPT connector.\n\nUse:\n`ChatGPT → Val Town → brain_bridge_jobs → persistent worker → canonical Brain`\n\nVal/project: `mosadek/project-brain-live-v1-durable` \nProtocol: `BRAIN_VAL_BRIDGE_PROTOCOL.md`\n\nThe first external project call in a new chat is Val Town, not Sprites.\n\n## Fail-closed boot sequence\n\n1. Read this bootstrap and the current `BRAIN_VAL_BRIDGE_PROTOCOL.md` through Val Town.\n2. Read `brain_bridge_worker.ts /health`.\n3. If health is not HTTP 200 with a fresh worker heartbeat, fail closed for live Brain operations. Do not confuse `endpoint_ok` with a live executor.\n4. Submit a unique `status` Brain job with an integer timeout ≤120.\n5. Wait for that exact job to become COMPLETE or FAILED.\n6. Run `verify-chain` and `verify-claim-graph`.\n7. Determine the correct workstream from verified live state.\n8. Register a unique CHAT agent with `register-agent`, declaring only capabilities actually present.\n9. Never claim `human_authority_approval`.\n10. Claim a causally ready task with `claim`.\n11. Continue through the Val queue.\n\n## Important: no atomic boot alias\n\nDo NOT submit `boot` or raw `boot-agent`.\n\nThe old bridge documentation was wrong end-to-end:\n- live Brain kernel command: `boot-agent`;\n- persistent executor currently rejects raw `boot-agent`;\n- old public bridge alias `boot` reached Brain literally and failed argparse.\n\nCurrent proven boot equivalent:\n\n`register-agent → claim`\n\nThis preserves the kernel’s registration and scheduler semantics without inventing an unavailable wrapper.\n\n## Queue contract\n\nBrain payload:\n\n```json\n{\"args\":[\"status\"],\"timeout\":60}\n```\n\nCurrent transport limits:\n- priority cap: 1,000,000,000;\n- all over-cap priorities tie and use FIFO;\n- Brain timeout: 1..120 seconds;\n- queue lease: 180 seconds;\n- atomic single-flight per worker ID;\n- no redelivery while a worker has an unexpired active lease.\n\nDo not try to defeat queue fairness by using huge floating-point priorities. Humanity already ran that experiment.\n\n## Supported Brain commands\n\nCurrently allowed:\n- status\n- verify-chain\n- verify-claim-graph\n- register-agent\n- ensure-task\n- delegate-task\n- claim\n- renew-lease\n- commit\n- checkpoint\n- add-claim\n- invalidate-claim\n- supersede-task-context\n- migrate-task-invariants\n- reconcile-causal-blocks\n\nCurrently unavailable end-to-end:\n- boot\n- boot-agent\n- recover-leases\n- recover-stale\n- arbitrary/unlisted brain.py subcommands\n\nIf an unavailable operation is required, route a bridge-extension task. Do not guess aliases.\n\n## Read-only Brain text\n\nUse `op='read_text'` only for:\n- `/brain/JOIN_PROTOCOL.md`;\n- non-directory files below `/brain/artifacts/`.\n\nMaximum 200,000 bytes. Closed payload schema. No traversal segments.\n\n## Worker health\n\nThe Val endpoint can be alive while the persistent worker is dead.\n\nTreat:\n- HTTP 200 = transport worker heartbeat currently healthy;\n- HTTP 503 = degraded/down/inconsistent transport. Inspect the response and traces.\n\nWhen health is 503, queued jobs may remain READY. Do not invent their results.\n\n## Direct Sprites emergency boundary\n\nDirect Sprites is not an automatic fallback.\n\nUse a non-Sprites route or extend the bridge first. Direct Sprites is reserved for an explicitly authorized maintenance emergency after acknowledging it can trigger the platform materialization approval.\n\n## After every task\n\n1. preserve consequential evidence and hashes;\n2. reconcile current workstream generation;\n3. commit through the Brain;\n4. verify chain/claim graph when consequential;\n5. claim the next eligible task;\n6. continue unless mission complete or a genuine external boundary remains.\n\n## Goal\n\nA new chat must be able to join the same canonical Brain without recurring Sprites connector approvals, while failures remain visible instead of being laundered into fake liveness.\n",[],[147,495],"48e2b399-c9d6-42c8-883a-f065510bf17c","BRAIN_VAL_BRIDGE_PROTOCOL.md","01a07b80-b4d6-73c0-ae85-463f030ff46f",["D",1788791971867],"# PROJECT BRAIN VAL BRIDGE PROTOCOL V2\n\n## Purpose\n\nNormal ChatGPT project work uses Val Town as the only ChatGPT-facing transport to the canonical Project Brain. Direct Sprites connector calls are maintenance-only because they can trigger separate file-materialization approval prompts.\n\nNormal path:\n\n`ChatGPT → Val Town → brain_bridge_jobs → persistent Brain worker → canonical Brain`\n\nVal/project: `mosadek/project-brain-live-v1-durable` \nQueue: `brain_bridge_jobs` \nWorker identity: `project-brain-live-v1-worker-v2`\n\n## Mandatory health interpretation\n\nThe HTTP endpoint being reachable is NOT proof that the persistent Brain worker is alive.\n\nRead `brain_bridge_worker.ts /health`.\n\n- HTTP 200 means the most recent worker poll is fresh and the queue has no expired lease or duplicate active lease for one worker ID.\n- HTTP 503 means fail closed. Inspect `worker_state`, `worker_reason`, queue counts, and endpoint traces.\n- `endpoint_ok:true` only proves the Val endpoint itself is executing.\n- `instance_identity_available:false` means the persistent worker has not yet supplied a distinct process instance ID. Do not overclaim process identity.\n\nCurrent Val-side invariants:\n- priority cap: `1_000_000_000`;\n- selection above the cap: FIFO by `created_at,id`;\n- maximum Brain command timeout: `120 seconds`;\n- queue lease: `180 seconds`;\n- atomic single-flight per `worker_id`;\n- an active unexpired lease is not redelivered to another poll sharing that worker ID;\n- a pre-existing duplicate active lease for one worker ID fails closed;\n- expired queue leases are returned to READY on a worker poll;\n- results are accepted only for the current unexpired lease owner.\n\nThese are transport invariants, not Brain authority.\n\n## Submit a Brain command\n\nInsert a unique job:\n\n```sql\nINSERT INTO brain_bridge_jobs\n(id, priority, op, payload_json, state, lease_owner, lease_expires_at,\n result_json, error_json, created_at, updated_at)\nVALUES (?, ?, 'brain', ?, 'READY', NULL, NULL, NULL, NULL,\n datetime('now'), datetime('now'))\n```\n\nBrain payload is closed-schema:\n\n```json\n{\"args\":[\"status\"],\"timeout\":60}\n```\n\nRequirements:\n- exact top-level keys: `args`, `timeout`;\n- `args` is a non-empty string array;\n- `timeout` is an integer from 1 through 120.\n\nCurrently allowed Brain subcommands:\n- status\n- verify-chain\n- verify-claim-graph\n- register-agent\n- ensure-task\n- delegate-task\n- claim\n- renew-lease\n- commit\n- checkpoint\n- add-claim\n- invalidate-claim\n- supersede-task-context\n- migrate-task-invariants\n- reconcile-causal-blocks\n\nAnything else fails at Val-side dispatch rather than being sent onward.\n\n## Boot semantics\n\nThere is currently NO valid atomic `boot` bridge command.\n\nThe public bridge previously advertised `boot`, but the live kernel accepts `boot-agent` while the persistent executor rejects raw `boot-agent`. Therefore neither spelling is a valid end-to-end bridge operation.\n\nUse the proven equivalent sequence:\n\n1. `register-agent`\n2. `claim`\n\nRegister only capabilities actually present in the current chat. Never claim `human_authority_approval`.\n\nExample conceptual sequence:\n\n```text\nregister-agent --workstream --role \n --type CHAT --capabilities \n\nclaim --agent --mode INTERACTIVE --lease-seconds 1800\n```\n\nDo not submit `boot` or `boot-agent` until a later verified bridge/executor revision explicitly restores an atomic wrapper.\n\n## Lease recovery semantics\n\nDo not submit `recover-leases` or `recover-stale` through this bridge revision.\n\n- Val transport queue lease expiry is recovered automatically by the worker on poll.\n- Canonical Brain task-lease recovery is a separate operation and is not currently exposed end-to-end by the persistent executor.\n- If canonical stale-lease recovery becomes necessary, create/route a bridge-extension task or use another verified non-Sprites route. Do not guess an alias.\n\n## Poll a job result\n\n```sql\nSELECT id,state,lease_owner,lease_expires_at,result_json,error_json,updated_at\nFROM brain_bridge_jobs\nWHERE id=?\n```\n\nTerminal states:\n- COMPLETE\n- FAILED\n\nA READY job means it has not been executed. A LEASED job is not complete. Do not infer canonical mutation from queue state alone.\n\n## Read Brain text without Sprites\n\nUse `op='read_text'` with exact closed-schema payload:\n\n```json\n{\"path\":\"/brain/JOIN_PROTOCOL.md\",\"max_bytes\":200000}\n```\n\nAllowed paths:\n- exactly `/brain/JOIN_PROTOCOL.md`;\n- a non-directory file strictly below `/brain/artifacts/`.\n\nConstraints:\n- `max_bytes`: integer 1..200000;\n- no `.` or `..` path segments;\n- no backslash or NUL;\n- no extra payload fields.\n\nEarlier worker stalls coincided with read jobs, but later bounded artifact reads completed successfully. Therefore do not claim that `read_text` itself caused the historical stall. Keep the bounded allowlist and use current worker health as the liveness signal.\n\n## Hard transport rule\n\nRoutine ChatGPT work:\n- DO NOT call Sprites;\n- DO NOT call Sprites.exec;\n- DO NOT call Sprites.file_read/file_write/file_copy/file_delete;\n- DO NOT call Sprites service/checkpoint/file/blob operations.\n\nIf a required operation is missing:\n1. use an existing valid non-Sprites substrate when possible;\n2. route or build a bridge extension;\n3. fail closed if the missing operation is necessary;\n4. direct Sprites remains an explicit maintenance emergency, not an automatic fallback.\n\n## Failure behavior\n\nIf jobs stay READY:\n1. inspect `/health`;\n2. inspect worker endpoint traces;\n3. inspect the current active/expired queue leases;\n4. do not raise transport priorities above the cap to win a queue arms race;\n5. do not interpret the Val endpoint being online as the Brain worker being online.\n\nIf worker health is DOWN:\n- queued commands remain pending;\n- no live Brain registration, claim, commit, status, or verification should be invented;\n- Val-side code/evidence work may continue when it does not pretend to mutate canonical Brain;\n- repair/restore the persistent executor through an authorized route, then resume queue processing.\n\n## Proven facts and bounded claims\n\nThe reverse bridge has successfully:\n- read Brain status;\n- created canonical Brain tasks;\n- registered CHAT agents;\n- claimed tasks;\n- committed task results;\n- run verify-chain and verify-claim-graph.\n\nThe Val-side worker has independently reproduced and repaired the same-worker concurrent lease race in isolated queue tests. This does NOT prove the persistent Sprite-side executor is permanently supervised or continuously alive.\n\n## Goal\n\nNormal project work must stay materialization-free from ChatGPT while remaining fail-closed:\n\n`ChatGPT agent → Val Town → durable queue → live worker → verified Brain`\n\nIf the live worker disappears, the system must say so rather than smiling with HTTP 200 like a malfunctioning status page.\n",[],[147,502],["D",1788778427608],[209,210,211,212,213,214,215,216,217,218,219,220,221,222,223,224,225,226,227,228,229,230,231,232,233,234,235,236,237,238,239,240,241,242,243,244],[147],"b4fb838e-ad28-4685-905d-b20694394de3","01a07b80-917a-70c9-9bdd-724f11870340",3,["D",1788791970521],[],[154,255],"9710492f-10e8-41e6-94f5-7b68cb51eff4","01a07b80-917a-70c9-9bdd-6fdbcf56575a",["D",1788791970521],[],[154,263],"97d2b498-3620-4ead-beee-165fa6103737",["D",1788791970521],[],[154,270],"c551bde9-702d-48d6-950c-479a0257040c","01a07b80-917a-70c9-9bdd-78afce09cb19",["D",1788791970521],[],[154,278],"97d4a3da-a9f1-45ce-b3bb-5d6cae672a9c","01a07b80-917a-70c9-9bdd-7d4a1f990d65",["D",1788791970521],[],[154,285],"1de64f76-baaa-4455-b8cd-88852f4c3033","01a07b80-917a-70c9-9bdd-842e3b1af7dd",["D",1788791970521],[],[154,292],"30bae13f-3c70-4eff-bd10-e4338af17a87","01a07b80-917a-70c9-9bdd-833574708179",["D",1788791970521],[],[154,299],"effd3f9c-d81f-44dc-99b6-827d8d71093e","01a07b80-917a-70c9-9bdd-892061b47c6a",["D",1788791970521],[],[154,306],"c43705fa-de3b-40af-a30d-918fe5624d8c","01a07b80-917b-72fb-80d5-523a7f2a9f01",["D",1788791970521],[],[154,313],"d93ee375-8547-472d-b2b0-3aa7ca5bcbe3","01a07b80-917b-72fb-80d5-55f3ed61311d",["D",1788791970521],[],[154,320],"f313bc99-a1e4-4120-90eb-4fb150d91f2d","01a07b80-917e-7744-959e-df520536a03f",["D",1788791970521],[],[154,327],"a81781b4-5703-4a96-9ec3-2bfd82d0bd31","01a07b80-917e-7744-959e-d9b97df48478",["D",1788791970521],[],[154,334],"b04c7845-bc79-44a3-b8d7-b8ee4d0c7346","01a07b80-917e-7744-959e-e3057e327a5c",["D",1788791970521],[],[154,341],"fc5066b7-a472-4eb4-8fbd-4c909005263b","01a07b80-917e-7744-959e-ee13af96d331",["D",1788791970521],[],[154,348],"a0e07c77-0412-49fb-9c7c-ab019322bc51","01a07b80-917e-7744-959e-f19fe1d19318",["D",1788791970521],[],[154,355],"ca3a72f5-b177-4adf-ab2a-967f276baf58","01a07b80-917e-7744-959e-f6eec71bc018",["D",1788791970521],[],[154,362],"fe80983b-aca1-43c0-82b8-3983d0de97c4","instance_affinity_wd1_test.ts","01a07b80-917e-7744-959e-f983be3c1f35",["D",1788791970521],"import { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\nimport {\n leaseOneSql, normalizeDispatch, healthHttpStatus, legacyLeaseRiskLeases,\n LEGACY_RISK_HORIZON_SECONDS\n} from \"./brain_bridge_worker.ts\";\n\nconst T=\"affinity_wd1_\"+crypto.randomUUID().replaceAll(\"-\",\"\");\nconst out:any={tests:[],failures:[]};\nconst ok=(name:string,cond:boolean,detail:any={})=>{out.tests.push({name,ok:!!cond,detail});if(!cond)out.failures.push(name)};\nawait sqlite.execute(`CREATE TABLE ${T}(\n id TEXT PRIMARY KEY,priority REAL NOT NULL DEFAULT 0,op TEXT NOT NULL,payload_json TEXT NOT NULL,\n state TEXT NOT NULL DEFAULT 'READY',lease_owner TEXT,lease_expires_at TEXT,result_json TEXT,error_json TEXT,\n created_at TEXT NOT NULL,updated_at TEXT NOT NULL)`);\ntry{\n const valid=JSON.stringify({args:[\"recover-stale\"],timeout:60});\n const malformed=JSON.stringify({args:[\"recover-stale\",\"--unexpected\"],timeout:60});\n const ordinary=JSON.stringify({args:[\"status\"],timeout:60});\n await sqlite.execute({sql:`INSERT INTO ${T}(id,priority,op,payload_json,state,created_at,updated_at) VALUES\n ('valid-recovery',100,'brain',?,'READY','2026-01-01 00:00:00','2026-01-01 00:00:00'),\n ('malformed-recovery',99,'brain',?,'READY','2026-01-01 00:00:01','2026-01-01 00:00:01'),\n ('ordinary',1,'brain',?,'READY','2026-01-01 00:00:02','2026-01-01 00:00:02')`,args:[valid,malformed,ordinary]});\n\n const legacy:any=await sqlite.execute({sql:leaseOneSql(T,false),args:[\"project-brain-live-v1-worker-v2\",\"project-brain-live-v1-worker-v2\"]});\n ok(\"legacy_skips_all_recover_stale_shapes\",legacy.rows?.[0]?.id===\"ordinary\",{leased:legacy.rows?.[0]});\n await sqlite.execute(`UPDATE ${T} SET state='READY',lease_owner=NULL,lease_expires_at=NULL`);\n\n const attested:any=await sqlite.execute({sql:leaseOneSql(T,true),args:[\"project-brain-live-v1-worker-v2\",\"project-brain-live-v1-worker-v2\"]});\n ok(\"attested_prioritizes_exact_valid_recovery\",attested.rows?.[0]?.id===\"valid-recovery\",{leased:attested.rows?.[0]});\n ok(\"malformed_recovery_rejected_before_brain\",\n !normalizeDispatch(\"brain\",malformed).ok &&\n (normalizeDispatch(\"brain\",malformed) as any).error===\"RECOVER_STALE_ARGS_INVALID\",\n normalizeDispatch(\"brain\",malformed));\n\n ok(\"legacy_risk_horizon_covers_dynamic_successor_max\",LEGACY_RISK_HORIZON_SECONDS===240,{LEGACY_RISK_HORIZON_SECONDS});\n const ageGap:any=await sqlite.execute({sql:`SELECT\n datetime('now','-200 seconds') >= datetime('now','-' || ? || ' seconds') AS within_new,\n datetime('now','-200 seconds') >= datetime('now','-180 seconds') AS within_old`,args:[LEGACY_RISK_HORIZON_SECONDS]});\n ok(\"legacy_200s_heartbeat_new_horizon_closes_old_gap\",\n Number(ageGap.rows?.[0]?.within_new)===1 && Number(ageGap.rows?.[0]?.within_old)===0,\n ageGap.rows?.[0]);\n ok(\"legacy_active_lease_with_risk_fails_health_closed\",\n healthHttpStatus(\"HEALTHY\",0,0,legacyLeaseRiskLeases(1,1),1)===503);\n ok(\"single_attested_no_legacy_risk_can_be_healthy\",\n healthHttpStatus(\"HEALTHY\",0,0,legacyLeaseRiskLeases(1,0),1)===200);\n ok(\"zero_recent_expected_instances_fails_closed\",healthHttpStatus(\"HEALTHY\",0,0,0,0)===503);\n ok(\"multiple_recent_expected_instances_fails_closed\",healthHttpStatus(\"HEALTHY\",0,0,0,2)===503);\n} finally {await sqlite.execute(`DROP TABLE IF EXISTS ${T}`);}\nout.summary={passed:out.tests.filter((x:any)=>x.ok).length,failed:out.failures.length,total:out.tests.length};\nconsole.log(JSON.stringify(out,null,2));\nif(out.failures.length)throw new Error(\"INSTANCE_AFFINITY_WD1_FAILURE:\"+out.failures.join(\",\"));\nexport default out;",[],[154,592],"2aa3cf38-9cc1-4ed5-8e8b-4e8a50712bdd","01a07b80-917e-7744-959e-fef94aeaec83",["D",1788791970521],[],[154,369],"09b39cda-4ca2-435d-8250-cf0674705242","01a07b80-917e-7744-959f-02a2238e31e2",["D",1788791970521],[],[154,376],"f75761b9-b5c7-4175-8a7f-18e575507287","01a07b80-917e-7744-959f-0402a1cf7484",["D",1788791970521],[],[154,383],"27e9be76-0186-4c89-87ce-1f748fa14ed0","01a07b80-917e-7744-959f-0e98dd7b255f",["D",1788791970521],[],[154,390],"ce84cbf3-3aa6-4a45-82ee-ff8982ba22b9","01a07b80-917e-7744-959f-09706b876045",["D",1788791970521],[],[154,397],"1f9ccca2-0268-4093-9316-1cd9211fba12","01a07b80-917e-7744-959f-1046735b8ad3",["D",1788791970521],[],[154,404],"754e647a-63c3-4314-b5c2-029f2b25d714","01a07b80-917e-7744-959f-171bbb357d0a",["D",1788791970521],[],[154,411],"97b2ccd7-5336-4e9c-ad0c-24949704cd67","hash_wd1.ts","01a07b80-917e-7744-959f-1bdec5e65cbb",["D",1788791970521],"async function sha(path:string){\n const res=await fetch(new URL(\"./\"+path,import.meta.url));\n const text=await res.text();\n const bytes=new TextEncoder().encode(text);\n const digest=await crypto.subtle.digest(\"SHA-256\",bytes);\n return {path,http:res.status,bytes:bytes.length,sha256:Array.from(new Uint8Array(digest)).map(b=>b.toString(16).padStart(2,\"0\")).join(\"\")};\n}\nconst files=[];\nfor(const p of [\"brain_bridge_worker.ts\",\"instance_affinity_wd1_test.ts\",\"heartbeat_scope_integration.ts\",\"brain_bridge_recovery_first_test_0120.ts\",\"instance_affinity_gap_test.ts\"]){files.push(await sha(p));}\nconsole.log(JSON.stringify({files},null,2));\nexport default {files};",[],[154,634],"368cf550-c01e-476a-a9ae-5f0d007a6248","01a07b80-917e-7744-959f-1f41b8dcb7d8",["D",1788791970521],[],[154,418],"e04d8f74-7ec3-41ad-ba40-f47bc39a327e","01a07b80-917e-7744-959f-23253ce6ab7a",["D",1788791970521],[],[154,425],"1af9bee8-5b0f-4d71-8d2d-b4179e994ee6","01a07b80-917e-7744-959f-251717844a5f",["D",1788791970521],[],[154,432],"89e0d6f9-a65e-4462-ac76-2c63a8e4385a","01a07b80-917e-7744-959f-2f42dcb55c76",["D",1788791970521],[],[154,439],"fa0b3726-3bf3-4f64-9e41-1085c951f0b0","01a07b80-917e-7744-959f-31f8f0930f3e",["D",1788791970521],[],[154,446],"7aeb770e-7243-487d-80de-26566c7f0126","01a07b80-917e-7744-959f-36aeefb05fbd",["D",1788791970521],[],[154,453],"29fcae84-a480-4c08-9eba-ae1616419270","01a07b80-917e-7744-959f-3e406ced83dc",["D",1788791970521],[],[154,460],"b23d60f4-697b-4d76-b8f7-0cbeed2a6349","01a07b80-917e-7744-959f-38b4d9234243",["D",1788791970521],[],[154,467],"ac374516-f812-46f1-85ee-0a491494223e","01a07b80-917e-7744-959f-428e2b681f4f",["D",1788791970521],"import { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\n\nconst WORKER_TOKEN = Deno.env.get(\"BRAIN_BRIDGE_WORKER_TOKEN\") || \"\";\nconst JOB_TABLE = \"brain_bridge_jobs\";\nconst WORKER_TABLE = \"brain_bridge_workers_v6\";\nconst EXPECTED_WORKER_ID = \"project-brain-live-v1-worker-v2\";\nexport const STALE_SECONDS = 90;\nexport const DEAD_SECONDS = 180;\nexport const PRIORITY_CAP = 1_000_000_000;\nexport const MAX_JOB_TIMEOUT = 120;\nexport const LEASE_SECONDS = 180;\n// Conservative cutover fence: must cover the largest transport lease admitted by the\n// current liveness successor family (up to 240s), not merely today's fixed 180s lease.\nexport const LEGACY_RISK_HORIZON_SECONDS = 240;\nexport const MAX_READ_BYTES = 200_000;\n\nexport const SUPPORTED_BRAIN_COMMANDS = [\n \"status\",\n \"verify-chain\",\n \"verify-claim-graph\",\n \"register-agent\",\n \"ensure-task\",\n \"delegate-task\",\n \"claim\",\n \"renew-lease\",\n \"commit\",\n \"checkpoint\",\n \"add-claim\",\n \"invalidate-claim\",\n \"supersede-task-context\",\n \"migrate-task-invariants\",\n \"reconcile-causal-blocks\",\n \"recover-stale\"\n] as const;\nconst SUPPORTED = new Set(SUPPORTED_BRAIN_COMMANDS);\n\nfunction json(v:unknown,status=200){return Response.json(v,{status});}\nfunction tableName(table:string){if(!/^[A-Za-z_][A-Za-z0-9_]*$/.test(table))throw new Error(\"BAD_TABLE\");return table;}\n\nexport function classifyWorkerAge(ageSeconds:number|null){\n if(ageSeconds===null || !Number.isFinite(ageSeconds)) return {state:\"UNKNOWN\",reason:\"NO_WORKER_HEARTBEAT\"};\n if(ageSeconds<=STALE_SECONDS) return {state:\"HEALTHY\",reason:\"RECENT_WORKER_POLL\"};\n if(ageSeconds<=DEAD_SECONDS) return {state:\"DEGRADED\",reason:\"WORKER_POLL_STALE\"};\n return {state:\"DOWN\",reason:\"WORKER_POLL_DEAD\"};\n}\nexport function effectivePriority(x:number){if(!Number.isFinite(x))return 0;return Math.min(x,PRIORITY_CAP);}\nexport function healthHttpStatus(workerState:string,duplicateActiveLeases:number,expiredLeases:number,legacyUnattestedActiveLeases=0,recentInstanceCount=1){\n return workerState===\"HEALTHY\" && duplicateActiveLeases===0 && expiredLeases===0 && legacyUnattestedActiveLeases===0 && recentInstanceCount===1 ? 200 : 503;\n}\nexport function legacyLeaseRiskLeases(leasedCount:number,legacyRiskCount:number){\n return legacyRiskCount>0 && leasedCount>0 ? leasedCount : 0;\n}\nexport function activeLeaseDecision(rows:any[]){\n if(rows.length>1)return {kind:\"conflict\" as const,count:rows.length};\n if(rows[0])return {kind:\"busy\" as const,active_job_id:String(rows[0].id),lease_expires_at:rows[0].lease_expires_at};\n return {kind:\"free\" as const};\n}\n\nexport function recoverExpiredSql(table=JOB_TABLE){\n table=tableName(table);\n return `UPDATE ${table}\n SET state='READY',lease_owner=NULL,lease_expires_at=NULL,updated_at=datetime('now')\n WHERE state='LEASED' AND lease_expires_at IS NOT NULL AND lease_expires_at <= datetime('now')`;\n}\nexport function activeLeaseSql(table=JOB_TABLE){\n table=tableName(table);\n return `SELECT id,op,payload_json,priority,lease_expires_at\n FROM ${table}\n WHERE state='LEASED' AND lease_owner=? AND lease_expires_at > datetime('now')\n ORDER BY lease_expires_at,id LIMIT 2`;\n}\nexport function isAttestedInstance(instance:string){return !!instance && instance!==\"LEGACY_UNATTESTED_INSTANCE\";}\nfunction anyRecoverCommandPredicate(alias=\"j\"){\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]')='recover-stale')`;\n}\nfunction exactRecoverPredicate(alias=\"j\"){\n return `(${anyRecoverCommandPredicate(alias)}\n AND json_array_length(json_extract(${alias}.payload_json,'$.args'))=1\n AND json_type(${alias}.payload_json,'$.timeout')='integer'\n AND json_extract(${alias}.payload_json,'$.timeout') BETWEEN 1 AND ${MAX_JOB_TIMEOUT}\n AND (SELECT COUNT(*) FROM json_each(${alias}.payload_json))=2)`;\n}\nexport function leaseOneSql(table=JOB_TABLE,allowRecovery=true){\n table=tableName(table);\n const anyRecover=anyRecoverCommandPredicate(\"j\");\n const recover=exactRecoverPredicate(\"j\");\n // A legacy/unattested instance must not lease *any* recover-stale-shaped command,\n // including malformed variants. Attested instances may lease them; dispatch then\n // rejects malformed payloads before canonical Brain execution.\n const recoveryEligibility=allowRecovery ? \"1=1\" : `NOT ${anyRecover}`;\n const recoveryOrder=allowRecovery ? `CASE WHEN ${recover} THEN 0 ELSE 1 END` : \"1\";\n return `UPDATE ${table}\n SET state='LEASED',lease_owner=?,lease_expires_at=datetime('now','+${LEASE_SECONDS} seconds'),updated_at=datetime('now')\n WHERE id=(\n SELECT j.id FROM ${table} j\n WHERE j.state='READY'\n AND (${recoveryEligibility})\n AND NOT EXISTS(\n SELECT 1 FROM ${table} x\n WHERE x.state='LEASED' AND x.lease_owner=? AND x.lease_expires_at > datetime('now')\n )\n ORDER BY\n ${recoveryOrder} ASC,\n CASE WHEN j.priority > ${PRIORITY_CAP} THEN ${PRIORITY_CAP} 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`;\n}\nexport function resultSql(table=JOB_TABLE){\n table=tableName(table);\n return `UPDATE ${table}\n SET state=?,result_json=?,error_json=?,lease_expires_at=NULL,updated_at=datetime('now')\n WHERE id=? AND state='LEASED' AND lease_owner=? AND lease_expires_at > datetime('now')\n RETURNING id,state`;\n}\n\nexport type DispatchResult=\n | {ok:true;payload_json:string}\n | {ok:false;error:string};\n\nfunction exactKeys(q:any, expected:string[]){\n const got=Object.keys(q).sort();\n const want=[...expected].sort();\n return got.length===want.length && got.every((k,i)=>k===want[i]);\n}\n\nexport function normalizeDispatch(op:string,payloadJson:string):DispatchResult{\n let q:any;try{q=JSON.parse(payloadJson)}catch{return {ok:false,error:\"PAYLOAD_JSON_INVALID\"}}\n if(!q || typeof q!==\"object\" || Array.isArray(q))return {ok:false,error:\"PAYLOAD_OBJECT_REQUIRED\"};\n\n if(op===\"brain\"){\n if(!exactKeys(q,[\"args\",\"timeout\"]))return {ok:false,error:\"BRAIN_PAYLOAD_SCHEMA_NOT_CLOSED\"};\n if(!Array.isArray(q.args) || q.args.length<1 || q.args.some((x:any)=>typeof x!==\"string\"))return {ok:false,error:\"BRAIN_ARGS_INVALID\"};\n if(!Number.isInteger(q.timeout) || q.timeout<1 || q.timeout>MAX_JOB_TIMEOUT)return {ok:false,error:\"BRAIN_TIMEOUT_INVALID\"};\n const cmd=q.args[0];\n if(cmd===\"boot\")return {ok:false,error:\"BOOT_NOT_ATOMIC_USE_REGISTER_AGENT_THEN_CLAIM\"};\n if(cmd===\"boot-agent\")return {ok:false,error:\"RAW_BOOT_AGENT_NOT_BRIDGE_COMMAND\"};\n if(cmd===\"recover-leases\")return {ok:false,error:\"RECOVER_LEASE_ALIAS_NOT_AVAILABLE_ON_CURRENT_EXECUTOR\"};\n if(cmd===\"recover-stale\" && q.args.length!==1)return {ok:false,error:\"RECOVER_STALE_ARGS_INVALID\"};\n if(!SUPPORTED.has(cmd))return {ok:false,error:\"BRAIN_SUBCOMMAND_NOT_ALLOWED\"};\n return {ok:true,payload_json:JSON.stringify({args:q.args,timeout:q.timeout})};\n }\n\n if(op===\"read_text\"){\n if(!exactKeys(q,[\"path\",\"max_bytes\"]))return {ok:false,error:\"READ_TEXT_SCHEMA_NOT_CLOSED\"};\n if(typeof q.path!==\"string\")return {ok:false,error:\"READ_TEXT_PATH_REQUIRED\"};\n if(q.path.includes(\"\\0\") || q.path.includes(\"\\\\\") || q.path.split(\"/\").some((s:string)=>s===\".\" || s===\"..\")){\n return {ok:false,error:\"READ_TEXT_TRAVERSAL_REJECTED\"};\n }\n const artifactFile=q.path.startsWith(\"/brain/artifacts/\") && q.path.length>\"/brain/artifacts/\".length && !q.path.endsWith(\"/\");\n if(!(q.path===\"/brain/JOIN_PROTOCOL.md\" || artifactFile))return {ok:false,error:\"READ_TEXT_PATH_FORBIDDEN\"};\n if(!Number.isInteger(q.max_bytes) || q.max_bytes<1 || q.max_bytes>MAX_READ_BYTES)return {ok:false,error:\"READ_TEXT_MAX_BYTES_INVALID\"};\n return {ok:true,payload_json:JSON.stringify({path:q.path,max_bytes:q.max_bytes})};\n }\n return {ok:false,error:\"OP_UNSUPPORTED\"};\n}\n\nasync function ensureTables(){\n await sqlite.execute(`CREATE TABLE IF NOT EXISTS ${WORKER_TABLE} (\n endpoint_host TEXT NOT NULL,\n worker_id TEXT NOT NULL,\n instance_id TEXT NOT NULL,\n first_seen_at TEXT NOT NULL,\n last_poll_at TEXT,\n last_result_at TEXT,\n lease_count INTEGER NOT NULL DEFAULT 0,\n result_count INTEGER NOT NULL DEFAULT 0,\n updated_at TEXT NOT NULL,\n PRIMARY KEY(endpoint_host,worker_id,instance_id)\n )`);\n}\nfunction instanceOf(q:any){const v=String(q?.instance_id||\"\").trim();return v||\"LEGACY_UNATTESTED_INSTANCE\";}\nexport function endpointScope(req:Request){return new URL(req.url).host.toLowerCase();}\n\nasync function workerHealth(endpointHost:string){\n await ensureTables();\n const wr:any=await sqlite.execute({\n sql:`SELECT worker_id,instance_id,last_poll_at,last_result_at,lease_count,result_count,\n CAST((julianday('now')-julianday(last_poll_at))*86400 AS INTEGER) AS poll_age_seconds\n FROM ${WORKER_TABLE}\n WHERE endpoint_host=? AND worker_id=?\n ORDER BY last_poll_at DESC LIMIT 1`,\n args:[endpointHost,EXPECTED_WORKER_ID]\n });\n const w=wr.rows?.[0]||null;\n const ri:any=await sqlite.execute({\n sql:`SELECT COUNT(*) AS recent_instance_count\n FROM ${WORKER_TABLE}\n WHERE endpoint_host=? AND worker_id=?\n AND last_poll_at IS NOT NULL\n AND last_poll_at >= datetime('now', '-' || ? || ' seconds')`,\n args:[endpointHost,EXPECTED_WORKER_ID,STALE_SECONDS]\n });\n const recentInstanceCount=Number(ri.rows?.[0]?.recent_instance_count||0);\n const legacyRisk:any=await sqlite.execute({\n sql:`SELECT COUNT(*) AS legacy_risk_count\n FROM ${WORKER_TABLE}\n WHERE endpoint_host=? AND worker_id=?\n AND instance_id='LEGACY_UNATTESTED_INSTANCE'\n AND last_poll_at IS NOT NULL\n AND last_poll_at >= datetime('now', '-' || ? || ' seconds')`,\n args:[endpointHost,EXPECTED_WORKER_ID,LEGACY_RISK_HORIZON_SECONDS]\n });\n const legacyRiskCount=Number(legacyRisk.rows?.[0]?.legacy_risk_count||0);\n const qc:any=await sqlite.execute({\n sql:`SELECT\n SUM(CASE WHEN state='READY' THEN 1 ELSE 0 END) AS ready_count,\n SUM(CASE WHEN state='LEASED' THEN 1 ELSE 0 END) AS leased_count,\n SUM(CASE WHEN state='LEASED' AND lease_expires_at <= datetime('now') THEN 1 ELSE 0 END) AS expired_lease_count,\n SUM(CASE WHEN state='READY' AND priority > ? THEN 1 ELSE 0 END) AS overcap_ready_count,\n MIN(CASE WHEN state='READY' THEN created_at END) AS oldest_ready_at,\n MIN(CASE WHEN state='LEASED' THEN lease_expires_at END) AS earliest_lease_expiry\n FROM brain_bridge_jobs`,\n args:[PRIORITY_CAP]\n });\n const dup:any=await sqlite.execute(`\n SELECT COUNT(*) AS duplicate_worker_count FROM (\n SELECT lease_owner FROM brain_bridge_jobs\n WHERE state='LEASED' AND lease_expires_at > datetime('now') AND lease_owner IS NOT NULL\n GROUP BY lease_owner HAVING COUNT(*) > 1\n )`);\n const q=qc.rows?.[0]||{};\n const duplicateActiveLeases=Number(dup.rows?.[0]?.duplicate_worker_count||0);\n const cls=classifyWorkerAge(w?Number(w.poll_age_seconds):null);\n const expiredLeases=Number(q.expired_lease_count||0);\n const leasedCount=Number(q.leased_count||0);\n const expectedWorkerLeases:any=await sqlite.execute({\n sql:`SELECT COUNT(*) AS active_lease_count\n FROM ${JOB_TABLE}\n WHERE state='LEASED' AND lease_owner=? AND lease_expires_at > datetime('now')`,\n args:[EXPECTED_WORKER_ID]\n });\n const expectedWorkerActiveLeaseCount=Number(expectedWorkerLeases.rows?.[0]?.active_lease_count||0);\n // A legacy process can own a still-live 180s queue lease after its heartbeat has aged\n // beyond the 90s recent-instance window. Hold health closed for the full lease horizon\n // only when this expected logical worker still owns an active lease.\n const legacyUnattestedActiveLeases=legacyLeaseRiskLeases(expectedWorkerActiveLeaseCount,legacyRiskCount);\n const status=healthHttpStatus(cls.state,duplicateActiveLeases,expiredLeases,legacyUnattestedActiveLeases,recentInstanceCount);\n return {status,body:{\n endpoint_ok:true,\n service:\"brain-bridge-worker-v5-rebased-candidate\",\n worker:w,\n worker_state:cls.state,\n worker_reason:cls.reason,\n instance_identity_available:w ? w.instance_id!==\"LEGACY_UNATTESTED_INSTANCE\" : false,\n duplicate_active_worker_leases:duplicateActiveLeases,\n legacy_unattested_active_leases:legacyUnattestedActiveLeases,\n expected_worker_id:EXPECTED_WORKER_ID,\n recent_expected_worker_instances:recentInstanceCount,\n queue:q,\n transport_priority_cap:PRIORITY_CAP,\n max_brain_timeout_seconds:MAX_JOB_TIMEOUT,\n queue_lease_seconds:LEASE_SECONDS,\n legacy_risk_horizon_seconds:LEGACY_RISK_HORIZON_SECONDS,\n selection_policy:\"RECOVERY_FIRST_THEN_CLAMPED_PRIORITY_FIFO_SINGLE_FLIGHT\",\n atomic_single_flight:true,\n fail_closed_http_status:status\n }};\n}\n\nasync function rejectInvalidLease(worker:string,id:string,error:string){\n await sqlite.execute({\n sql:`UPDATE ${JOB_TABLE}\n SET state='FAILED',result_json=NULL,error_json=?,lease_expires_at=NULL,updated_at=datetime('now')\n WHERE id=? AND state='LEASED' AND lease_owner=?`,\n args:[JSON.stringify({classification:\"BRIDGE_DISPATCH_REJECTED\",error}),id,worker]\n });\n}\n\nexport default async function(req:Request):Promise{\n const u=new URL(req.url);\n const endpointHost=endpointScope(req);\n if(req.method===\"GET\" && u.pathname.endsWith(\"/health\")){\n const h=await workerHealth(endpointHost);return json(h.body,h.status);\n }\n if(req.method!==\"POST\")return json({ok:false,error:\"METHOD\"},405);\n const supplied=req.headers.get(\"x-brain-worker-token\")||\"\";\n if(!WORKER_TOKEN || supplied!==WORKER_TOKEN)return json({ok:false,error:\"UNAUTHORIZED\"},401);\n let q:any;try{q=await req.json()}catch{return json({ok:false,error:\"BAD_JSON\"},400)}\n await ensureTables();\n\n if(u.pathname.endsWith(\"/poll\")){\n const worker=String(q.worker_id||\"\").trim();\n if(!worker || worker.length>128)return json({ok:false,error:\"WORKER_REQUIRED\"},400);\n if(worker!==EXPECTED_WORKER_ID)return json({ok:false,error:\"WORKER_ID_MISMATCH\"},403);\n const instance=instanceOf(q);\n await sqlite.execute({\n sql:`INSERT INTO ${WORKER_TABLE}(endpoint_host,worker_id,instance_id,first_seen_at,last_poll_at,updated_at)\n VALUES(?,?,?,datetime('now'),datetime('now'),datetime('now'))\n ON CONFLICT(endpoint_host,worker_id,instance_id) DO UPDATE SET last_poll_at=datetime('now'),updated_at=datetime('now')`,\n args:[endpointHost,worker,instance]\n });\n\n await sqlite.execute(recoverExpiredSql());\n const ar:any=await sqlite.execute({sql:activeLeaseSql(),args:[worker]});\n const before=activeLeaseDecision(ar.rows||[]);\n if(before.kind===\"conflict\")return json({ok:false,error:\"MULTIPLE_ACTIVE_LEASES\",worker_id:worker,count:before.count},409);\n if(before.kind===\"busy\")return json({ok:true,job:null,reason:\"ACTIVE_LEASE_EXISTS\",active_lease:{id:before.active_job_id,lease_expires_at:before.lease_expires_at},worker_id:worker,instance_id:instance});\n\n const r:any=await sqlite.execute({sql:leaseOneSql(JOB_TABLE,isAttestedInstance(instance)),args:[worker,worker]});\n if(!r.rows?.[0]){\n return json({ok:true,job:null,reason:\"NO_READY_JOB_OR_RACED_ACTIVE_LEASE\",worker_id:worker,instance_id:instance,priority_cap:PRIORITY_CAP});\n }\n\n const row=r.rows[0];\n const normalized=normalizeDispatch(String(row.op),String(row.payload_json));\n if(!normalized.ok){\n await rejectInvalidLease(worker,String(row.id),normalized.error);\n return json({ok:true,job:null,reason:\"DISPATCH_REJECTED\",rejected_job:String(row.id),dispatch_error:normalized.error,worker_id:worker,instance_id:instance});\n }\n\n await sqlite.execute({\n sql:`UPDATE ${WORKER_TABLE} SET lease_count=lease_count+1,updated_at=datetime('now') WHERE endpoint_host=? AND worker_id=? AND instance_id=?`,\n args:[endpointHost,worker,instance]\n });\n return json({ok:true,job:{...row,payload_json:normalized.payload_json},worker_id:worker,instance_id:instance,priority_cap:PRIORITY_CAP,lease_seconds:LEASE_SECONDS});\n }\n\n if(u.pathname.endsWith(\"/result\")){\n const worker=String(q.worker_id||\"\").trim(),id=String(q.id||\"\").trim(),success=q.success===true;\n const instance=instanceOf(q);\n if(!worker||!id)return json({ok:false,error:\"BAD_RESULT_ID\"},400);\n if(worker!==EXPECTED_WORKER_ID)return json({ok:false,error:\"WORKER_ID_MISMATCH\"},403);\n const r:any=await sqlite.execute({\n sql:resultSql(),\n args:[success?\"COMPLETE\":\"FAILED\",success?JSON.stringify(q.result??null):null,success?null:JSON.stringify(q.error??null),id,worker]\n });\n if(!r.rows?.length)return json({ok:false,error:\"LEASE_MISMATCH_OR_EXPIRED\"},409);\n await sqlite.execute({\n sql:`UPDATE ${WORKER_TABLE} SET last_result_at=datetime('now'),result_count=result_count+1,updated_at=datetime('now') WHERE endpoint_host=? AND worker_id=? AND instance_id=?`,\n args:[endpointHost,worker,instance]\n });\n return json({ok:true,id,state:r.rows[0].state,worker_id:worker,instance_id:instance});\n }\n return json({ok:false,error:\"NOT_FOUND\"},404);\n}\n",[],[154,474],"40389488-b97c-487e-9e0a-841647a64bd1","01a07b80-917e-7744-959f-46294fef913c",["D",1788791970521],[],[154,481],"bf6200a3-bd3a-4a0a-ba36-8e483bf7e457","01a07b80-917e-7744-959e-e6e99069eb82",["D",1788791970521],[],[154,488],"3a77830b-9dd5-4051-a84e-01ea88fc175c","01a07b80-917e-7744-959e-e8df0b1de1d4",["D",1788791970521],[],[154,495],"379f18c7-2bf0-4c6e-918e-a56197444246","01a07b80-917e-7744-959f-2ba3b7809787",["D",1788791970521],[],[154,502],["D",1788778418560],[170,171,172,173,174,175,176,177,178,179,180,181,182,183,184,185,186,187,188,189,190,191,192,193,194,195,196,197,198,199,200,201,202,203,204,205,206,207],[154],["D",1788778403598],["D",1789477862254],{"_98":97,"_106":102},{"_98":97,"_99":100,"_101":102,"_18":53,"_103":104,"_105":24},{"_13":87,"_31":88,"_41":40,"_89":42,"_90":-5,"_91":-5,"_92":-5,"_93":-5,"_94":-5,"_95":43,"_96":97},"ctx",{"_80":-5,"_126":747,"_748":749,"_750":751,"_752":24,"_753":24,"_754":24,"_755":57,"_756":-5,"_757":-7,"_758":-7,"_759":61,"_760":24,"_761":24,"_762":-5,"_763":24,"_764":24,"_765":24,"_766":-5},"ENV",{"_718":719,"_720":721,"_722":88,"_723":724,"_725":726,"_727":728,"_729":730,"_731":732,"_733":734,"_735":736,"_737":738,"_739":740,"_741":742,"_743":744,"_745":746},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","RENDER_GIT_COMMIT","e87eb04e707cf64e7e532c8e8ec395f209e17f15","RENDER_GIT_BRANCH","POSTHOG_API_TOKEN","phc_nmoyuAkStEZuUp69rYlg1DZgrIt19Gx0Y4Hwf8tGgJP","POSTHOG_API_HOST","https://wart.val.town","WEB_API_TEMPLATE","https://{val}.web.val.run","APP_URL","https://www.val.town","MODULE_URL","https://esm.town","VANITY_WEB_API_TEMPLATE","https://{label}.val.run/","DENOLS_URL","https://lsp.val.town","NODE_ENV","production","CLOUDFLARE_TURNSTILE_SITE_KEY","0x4AAAAAACtaIZJH7s9rBMZ6","GOOGLE_CLIENT_ID","875989696899-jtsqkhlbdv5jrlsk8631p7ipjg3c6o62.apps.googleusercontent.com","STRIPE_PUBLISHABLE_KEY","pk_live_51N2zvWEpZTTLipIkVEwXrUG9AT0yeOOEYxszarZT1jpsZV58Ly6wlg3SltZpHN26CUalOBmUSY7adQRQiSkCZz2500qSXNkf8Y","API_URL","https://api.val.town",[],"preferencesKeybindings","default","preferencesTheme","light","preferencesFixers","preferencesCopilot","preferencesSelectionAi","preferencesCloseBrackets","preferencesChatPanelState","preferencesDprint","preferencesDenofmt","notificationCount","flagDenols","isBusinessOrgMember","businessOrgHandle","isBusinessOrgAdmin","isHigherTownieTier","navCollapsed","currentOrgId"]

Diff · v6