[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_743":744,"_745":746},"routes/_app.x.$handle.$name",{"_99":98,"_31":44,"_108":89,"_26":109,"_13":14,"_110":-5,"_11":111,"_112":113,"_114":115,"_116":117,"_118":119,"_20":-5,"_120":-5,"_121":-5,"_122":24,"_123":124,"_125":58,"_126":-5,"_127":-5,"_128":129},"routes/_app.x.$handle.$name.branch.$branch.version.$version.diff",{"_11":12,"_13":14,"_15":16,"_17":-5,"_18":-5},"project",{"_42":43,"_31":44,"_37":45,"_46":-5,"_47":24,"_48":49,"_50":49,"_51":52,"_53":-5,"_18":54,"_55":56,"_57":58,"_59":-5,"_60":-5,"_61":62,"_63":64,"_65":66,"_67":68,"_69":70,"_71":-5,"_72":73,"_74":73,"_75":76,"_77":76,"_78":76,"_79":73,"_80":73,"_81":82,"_83":84,"_85":86,"_87":24},"version",8,"changes",[19],"aiChatInfo","userId",{"_20":21,"_22":-7,"_23":24,"_25":24,"_26":27,"_28":27},"file",{"_29":30,"_31":32,"_33":34,"_35":36,"_37":38,"_39":14,"_40":41,"_23":24},"previous","deleted",false,"deletedHere","path","diagnostics/boot_cohort_starvation_red_v1.ts","latestPath","fileId","1e3b9f6a-aad1-11f1-8a2e-1607ee4eb77e","name","boot_cohort_starvation_red_v1.ts","fileType","script","content","import { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\nimport { leaseOneSql, PRIORITY_CAP } from \"./current_brain_bridge_worker.ts\";\nconst T=\"boot_starvation_red_\"+crypto.randomUUID().replaceAll(\"-\",\"\");\nconst p=(cmd:string)=>JSON.stringify({args:[cmd],timeout:60});\nconst reg=(id:string)=>JSON.stringify({args:[\"register-agent\",id,\"--workstream\",\"global\",\"--role\",\"r\",\"--type\",\"CHAT\",\"--capabilities\",\"[]\"],timeout:60});\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_instance_id TEXT,lease_attempt_id TEXT,\n transport_lease_generation INTEGER NOT NULL DEFAULT 0,lease_expires_at TEXT,result_json TEXT,error_json TEXT,\n created_at TEXT NOT NULL,updated_at TEXT NOT NULL)`);\nconst out:any={};\ntry{\n const ins=async(id:string,payload:string,ageSeconds:number)=>sqlite.execute({\n sql:`INSERT INTO ${T}(id,priority,op,payload_json,state,created_at,updated_at)\n VALUES(?,?,'brain',?,'READY',datetime('now','-'||?||' seconds'),datetime('now'))`,\n args:[id,PRIORITY_CAP,payload,ageSeconds]\n });\n // Live defect: a commit that has waited 5 minutes should not be leapfrogged forever by a fresh register.\n await ins(\"ordinary-aged\",p(\"commit\"),300);\n await ins(\"register-fresh\",reg(\"fresh-a\"),1);\n const r:any=await sqlite.execute({sql:leaseOneSql(T),args:[\"w\",\"w\"]});\n out.selected=r.rows?.[0]?.id??null;\n out.expected=\"ordinary-aged\";\n out.pass=out.selected===out.expected;\n console.log(JSON.stringify(out,null,2));\n if(!out.pass) throw new Error(\"EXPECTED_RED: aged ordinary job still starves behind fresh boot cohort\");\n}finally{await sqlite.execute(`DROP TABLE IF EXISTS ${T}`)}\n","createdAt",["D",1788795055718],"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",{"_99":98,"_107":103},"org",{"_99":98,"_100":101,"_102":103,"_18":54,"_104":105,"_106":24},"branch",{"_13":88,"_31":89,"_42":41,"_90":43,"_91":-5,"_92":-5,"_93":-5,"_94":-5,"_95":-5,"_96":44,"_97":98},"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",{"_42":43,"_31":44,"_37":738,"_46":-5,"_47":24,"_48":49,"_50":49,"_51":52,"_53":-5,"_18":54,"_55":56,"_57":58,"_59":-5,"_60":-5,"_61":62,"_63":64,"_65":66,"_67":68,"_69":739,"_71":-5,"_72":73,"_74":73,"_75":76,"_77":76,"_78":76,"_79":73,"_80":73,"_81":740,"_83":741,"_85":742,"_87":24},"tree",[181,184,223,260,261],"files",[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,247,248,249,250,251,252,253,254,255,256,257,258,259,260,261],"counts",{"_171":62,"_172":162,"_173":62,"_174":175,"_176":177},"contents",[130,131,132,133,134],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},{"_42":165,"_31":166,"_29":167,"_138":-5,"_40":41,"_39":168,"_140":58,"_37":169,"_13":62,"_33":157,"_35":-5,"_23":24,"_143":-5,"_26":170},{"_42":159,"_31":160,"_29":161,"_138":-5,"_40":41,"_39":162,"_140":58,"_37":163,"_13":62,"_33":157,"_35":-5,"_23":24,"_143":-5,"_26":164},{"_42":152,"_31":153,"_29":154,"_138":-5,"_40":41,"_39":155,"_140":58,"_37":156,"_13":62,"_33":157,"_35":-5,"_23":24,"_143":-5,"_26":158},{"_42":145,"_31":146,"_29":147,"_138":-5,"_40":41,"_39":148,"_140":58,"_37":149,"_13":62,"_33":34,"_35":150,"_23":24,"_143":-5,"_26":151},{"_42":135,"_31":136,"_29":137,"_138":-5,"_40":41,"_39":139,"_140":58,"_37":141,"_13":62,"_33":34,"_35":142,"_23":24,"_143":-5,"_26":144},"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",[136],"bc72139d-7fa4-4bfa-bedb-6baa28a6267e","gc_manifest_sha_v2.ts","a43a181e-aaca-11f1-a2b7-1607ee4eb77e",6,["D",1788792274049],"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",[146],"bd3a3a6c-7f22-4a9c-8d0e-13d6cd158156","instance-affinity-z7p3","01a07b80-b4d5-7124-b029-2e1fbc8ad6a4",2,["D",1788778427608],"directory",[153],"085158fb-637b-446a-b8c3-c9e8b1b0cbc5","instance-affinity-wd1-finalize","01a07b80-917a-70c9-9bdd-6b268d4d7168",1,["D",1788778418560],[160],"eeaf7f04-210b-43f0-b21e-ab013604855d","diagnostics","01a07c7e-6745-721c-8140-494e3ad0686d",7,["D",1788795053895],[166],"pulls","branches","forks","envVars",{"_178":62,"_180":62},"connections",{"_178":62,"_179":62},"count","unfilledCount","emptyCount",{"_42":165,"_31":166,"_29":167,"_138":-5,"_40":41,"_39":168,"_140":58,"_37":735,"_13":62,"_33":157,"_35":-5,"_23":24,"_143":-5,"_263":736,"_26":737},{"_42":731,"_31":32,"_29":30,"_138":167,"_40":41,"_39":14,"_140":58,"_37":732,"_13":62,"_33":34,"_35":36,"_23":24,"_143":-5,"_263":733,"_26":734},{"_42":724,"_31":725,"_29":726,"_138":167,"_40":41,"_39":168,"_140":24,"_37":727,"_13":62,"_33":288,"_35":728,"_23":24,"_143":-5,"_263":729,"_26":730},{"_42":159,"_31":160,"_29":161,"_138":-5,"_40":41,"_39":162,"_140":58,"_37":721,"_13":62,"_33":157,"_35":-5,"_23":24,"_143":-5,"_263":722,"_26":723},{"_42":716,"_31":517,"_29":717,"_138":161,"_40":41,"_39":528,"_140":58,"_37":718,"_13":162,"_33":20,"_35":520,"_23":24,"_143":-5,"_263":719,"_26":720},{"_42":711,"_31":510,"_29":712,"_138":161,"_40":41,"_39":528,"_140":58,"_37":713,"_13":162,"_33":20,"_35":513,"_23":24,"_143":-5,"_263":714,"_26":715},{"_42":706,"_31":503,"_29":707,"_138":161,"_40":41,"_39":528,"_140":58,"_37":708,"_13":162,"_33":20,"_35":506,"_23":24,"_143":-5,"_263":709,"_26":710},{"_42":701,"_31":496,"_29":702,"_138":161,"_40":41,"_39":528,"_140":58,"_37":703,"_13":162,"_33":34,"_35":499,"_23":24,"_143":-5,"_263":704,"_26":705},{"_42":695,"_31":489,"_29":696,"_138":161,"_40":41,"_39":528,"_140":58,"_37":697,"_13":162,"_33":288,"_35":698,"_23":24,"_143":-5,"_263":699,"_26":700},{"_42":690,"_31":482,"_29":691,"_138":161,"_40":41,"_39":528,"_140":58,"_37":692,"_13":162,"_33":34,"_35":485,"_23":24,"_143":-5,"_263":693,"_26":694},{"_42":685,"_31":475,"_29":686,"_138":161,"_40":41,"_39":528,"_140":58,"_37":687,"_13":162,"_33":34,"_35":478,"_23":24,"_143":-5,"_263":688,"_26":689},{"_42":680,"_31":468,"_29":681,"_138":161,"_40":41,"_39":528,"_140":58,"_37":682,"_13":162,"_33":34,"_35":471,"_23":24,"_143":-5,"_263":683,"_26":684},{"_42":675,"_31":461,"_29":676,"_138":161,"_40":41,"_39":528,"_140":58,"_37":677,"_13":162,"_33":34,"_35":464,"_23":24,"_143":-5,"_263":678,"_26":679},{"_42":670,"_31":454,"_29":671,"_138":161,"_40":41,"_39":528,"_140":58,"_37":672,"_13":162,"_33":34,"_35":457,"_23":24,"_143":-5,"_263":673,"_26":674},{"_42":665,"_31":447,"_29":666,"_138":161,"_40":41,"_39":528,"_140":58,"_37":667,"_13":162,"_33":288,"_35":450,"_23":24,"_143":-5,"_263":668,"_26":669},{"_42":660,"_31":440,"_29":661,"_138":161,"_40":41,"_39":528,"_140":58,"_37":662,"_13":162,"_33":34,"_35":443,"_23":24,"_143":-5,"_263":663,"_26":664},{"_42":655,"_31":433,"_29":656,"_138":161,"_40":41,"_39":528,"_140":58,"_37":657,"_13":162,"_33":34,"_35":436,"_23":24,"_143":-5,"_263":658,"_26":659},{"_42":648,"_31":649,"_29":650,"_138":161,"_40":41,"_39":528,"_140":58,"_37":651,"_13":162,"_33":34,"_35":652,"_23":24,"_143":-5,"_263":653,"_26":654},{"_42":643,"_31":426,"_29":644,"_138":161,"_40":41,"_39":528,"_140":58,"_37":645,"_13":162,"_33":34,"_35":429,"_23":24,"_143":-5,"_263":646,"_26":647},{"_42":638,"_31":419,"_29":639,"_138":161,"_40":41,"_39":528,"_140":58,"_37":640,"_13":162,"_33":34,"_35":422,"_23":24,"_143":-5,"_263":641,"_26":642},{"_42":633,"_31":412,"_29":634,"_138":161,"_40":41,"_39":528,"_140":58,"_37":635,"_13":162,"_33":34,"_35":415,"_23":24,"_143":-5,"_263":636,"_26":637},{"_42":628,"_31":405,"_29":629,"_138":161,"_40":41,"_39":528,"_140":58,"_37":630,"_13":162,"_33":288,"_35":408,"_23":24,"_143":-5,"_263":631,"_26":632},{"_42":623,"_31":398,"_29":624,"_138":161,"_40":41,"_39":528,"_140":58,"_37":625,"_13":162,"_33":34,"_35":401,"_23":24,"_143":-5,"_263":626,"_26":627},{"_42":618,"_31":391,"_29":619,"_138":161,"_40":41,"_39":528,"_140":58,"_37":620,"_13":162,"_33":34,"_35":394,"_23":24,"_143":-5,"_263":621,"_26":622},{"_42":613,"_31":384,"_29":614,"_138":161,"_40":41,"_39":528,"_140":58,"_37":615,"_13":162,"_33":34,"_35":387,"_23":24,"_143":-5,"_263":616,"_26":617},{"_42":606,"_31":607,"_29":608,"_138":161,"_40":41,"_39":528,"_140":58,"_37":609,"_13":162,"_33":34,"_35":610,"_23":24,"_143":-5,"_263":611,"_26":612},{"_42":601,"_31":377,"_29":602,"_138":161,"_40":41,"_39":528,"_140":58,"_37":603,"_13":162,"_33":34,"_35":380,"_23":24,"_143":-5,"_263":604,"_26":605},{"_42":596,"_31":370,"_29":597,"_138":161,"_40":41,"_39":528,"_140":58,"_37":598,"_13":162,"_33":34,"_35":373,"_23":24,"_143":-5,"_263":599,"_26":600},{"_42":591,"_31":363,"_29":592,"_138":161,"_40":41,"_39":528,"_140":58,"_37":593,"_13":162,"_33":288,"_35":366,"_23":24,"_143":-5,"_263":594,"_26":595},{"_42":586,"_31":356,"_29":587,"_138":161,"_40":41,"_39":528,"_140":58,"_37":588,"_13":162,"_33":34,"_35":359,"_23":24,"_143":-5,"_263":589,"_26":590},{"_42":581,"_31":349,"_29":582,"_138":161,"_40":41,"_39":528,"_140":58,"_37":583,"_13":162,"_33":34,"_35":352,"_23":24,"_143":-5,"_263":584,"_26":585},{"_42":576,"_31":342,"_29":577,"_138":161,"_40":41,"_39":528,"_140":58,"_37":578,"_13":162,"_33":288,"_35":345,"_23":24,"_143":-5,"_263":579,"_26":580},{"_42":571,"_31":335,"_29":572,"_138":161,"_40":41,"_39":528,"_140":58,"_37":573,"_13":162,"_33":288,"_35":338,"_23":24,"_143":-5,"_263":574,"_26":575},{"_42":566,"_31":328,"_29":567,"_138":161,"_40":41,"_39":528,"_140":58,"_37":568,"_13":162,"_33":288,"_35":331,"_23":24,"_143":-5,"_263":569,"_26":570},{"_42":561,"_31":321,"_29":562,"_138":161,"_40":41,"_39":528,"_140":58,"_37":563,"_13":162,"_33":288,"_35":324,"_23":24,"_143":-5,"_263":564,"_26":565},{"_42":556,"_31":314,"_29":557,"_138":161,"_40":41,"_39":528,"_140":58,"_37":558,"_13":162,"_33":34,"_35":317,"_23":24,"_143":-5,"_263":559,"_26":560},{"_42":551,"_31":307,"_29":552,"_138":161,"_40":41,"_39":528,"_140":58,"_37":553,"_13":162,"_33":288,"_35":310,"_23":24,"_143":-5,"_263":554,"_26":555},{"_42":546,"_31":300,"_29":547,"_138":161,"_40":41,"_39":528,"_140":58,"_37":548,"_13":162,"_33":288,"_35":303,"_23":24,"_143":-5,"_263":549,"_26":550},{"_42":541,"_31":293,"_29":542,"_138":161,"_40":41,"_39":528,"_140":58,"_37":543,"_13":162,"_33":288,"_35":296,"_23":24,"_143":-5,"_263":544,"_26":545},{"_42":537,"_31":285,"_29":56,"_138":161,"_40":41,"_39":528,"_140":58,"_37":538,"_13":162,"_33":288,"_35":289,"_23":24,"_143":-5,"_263":539,"_26":540},{"_42":532,"_31":278,"_29":533,"_138":161,"_40":41,"_39":528,"_140":58,"_37":534,"_13":162,"_33":34,"_35":281,"_23":24,"_143":-5,"_263":535,"_26":536},{"_42":526,"_31":270,"_29":527,"_138":161,"_40":41,"_39":528,"_140":58,"_37":529,"_13":162,"_33":34,"_35":274,"_23":24,"_143":-5,"_263":530,"_26":531},{"_42":152,"_31":153,"_29":154,"_138":-5,"_40":41,"_39":155,"_140":58,"_37":523,"_13":62,"_33":157,"_35":-5,"_23":24,"_143":-5,"_263":524,"_26":525},{"_42":516,"_31":517,"_29":518,"_138":154,"_40":41,"_39":272,"_140":58,"_37":519,"_13":162,"_33":20,"_35":520,"_23":24,"_143":-5,"_263":521,"_26":522},{"_42":509,"_31":510,"_29":511,"_138":154,"_40":41,"_39":272,"_140":58,"_37":512,"_13":162,"_33":20,"_35":513,"_23":24,"_143":-5,"_263":514,"_26":515},{"_42":502,"_31":503,"_29":504,"_138":154,"_40":41,"_39":272,"_140":58,"_37":505,"_13":162,"_33":20,"_35":506,"_23":24,"_143":-5,"_263":507,"_26":508},{"_42":495,"_31":496,"_29":497,"_138":154,"_40":41,"_39":272,"_140":58,"_37":498,"_13":162,"_33":34,"_35":499,"_23":24,"_143":-5,"_263":500,"_26":501},{"_42":488,"_31":489,"_29":490,"_138":154,"_40":41,"_39":272,"_140":58,"_37":491,"_13":162,"_33":288,"_35":492,"_23":24,"_143":-5,"_263":493,"_26":494},{"_42":481,"_31":482,"_29":483,"_138":154,"_40":41,"_39":272,"_140":58,"_37":484,"_13":162,"_33":34,"_35":485,"_23":24,"_143":-5,"_263":486,"_26":487},{"_42":474,"_31":475,"_29":476,"_138":154,"_40":41,"_39":272,"_140":58,"_37":477,"_13":162,"_33":34,"_35":478,"_23":24,"_143":-5,"_263":479,"_26":480},{"_42":467,"_31":468,"_29":469,"_138":154,"_40":41,"_39":272,"_140":58,"_37":470,"_13":162,"_33":34,"_35":471,"_23":24,"_143":-5,"_263":472,"_26":473},{"_42":460,"_31":461,"_29":462,"_138":154,"_40":41,"_39":272,"_140":58,"_37":463,"_13":162,"_33":34,"_35":464,"_23":24,"_143":-5,"_263":465,"_26":466},{"_42":453,"_31":454,"_29":455,"_138":154,"_40":41,"_39":272,"_140":58,"_37":456,"_13":162,"_33":34,"_35":457,"_23":24,"_143":-5,"_263":458,"_26":459},{"_42":446,"_31":447,"_29":448,"_138":154,"_40":41,"_39":272,"_140":58,"_37":449,"_13":162,"_33":288,"_35":450,"_23":24,"_143":-5,"_263":451,"_26":452},{"_42":439,"_31":440,"_29":441,"_138":154,"_40":41,"_39":272,"_140":58,"_37":442,"_13":162,"_33":34,"_35":443,"_23":24,"_143":-5,"_263":444,"_26":445},{"_42":432,"_31":433,"_29":434,"_138":154,"_40":41,"_39":272,"_140":58,"_37":435,"_13":162,"_33":34,"_35":436,"_23":24,"_143":-5,"_263":437,"_26":438},{"_42":425,"_31":426,"_29":427,"_138":154,"_40":41,"_39":272,"_140":58,"_37":428,"_13":162,"_33":34,"_35":429,"_23":24,"_143":-5,"_263":430,"_26":431},{"_42":418,"_31":419,"_29":420,"_138":154,"_40":41,"_39":272,"_140":58,"_37":421,"_13":162,"_33":34,"_35":422,"_23":24,"_143":-5,"_263":423,"_26":424},{"_42":411,"_31":412,"_29":413,"_138":154,"_40":41,"_39":272,"_140":58,"_37":414,"_13":162,"_33":34,"_35":415,"_23":24,"_143":-5,"_263":416,"_26":417},{"_42":404,"_31":405,"_29":406,"_138":154,"_40":41,"_39":272,"_140":58,"_37":407,"_13":162,"_33":288,"_35":408,"_23":24,"_143":-5,"_263":409,"_26":410},{"_42":397,"_31":398,"_29":399,"_138":154,"_40":41,"_39":272,"_140":58,"_37":400,"_13":162,"_33":34,"_35":401,"_23":24,"_143":-5,"_263":402,"_26":403},{"_42":390,"_31":391,"_29":392,"_138":154,"_40":41,"_39":272,"_140":58,"_37":393,"_13":162,"_33":34,"_35":394,"_23":24,"_143":-5,"_263":395,"_26":396},{"_42":383,"_31":384,"_29":385,"_138":154,"_40":41,"_39":272,"_140":58,"_37":386,"_13":162,"_33":34,"_35":387,"_23":24,"_143":-5,"_263":388,"_26":389},{"_42":376,"_31":377,"_29":378,"_138":154,"_40":41,"_39":272,"_140":58,"_37":379,"_13":162,"_33":34,"_35":380,"_23":24,"_143":-5,"_263":381,"_26":382},{"_42":369,"_31":370,"_29":371,"_138":154,"_40":41,"_39":272,"_140":58,"_37":372,"_13":162,"_33":34,"_35":373,"_23":24,"_143":-5,"_263":374,"_26":375},{"_42":362,"_31":363,"_29":364,"_138":154,"_40":41,"_39":272,"_140":58,"_37":365,"_13":162,"_33":288,"_35":366,"_23":24,"_143":-5,"_263":367,"_26":368},{"_42":355,"_31":356,"_29":357,"_138":154,"_40":41,"_39":272,"_140":58,"_37":358,"_13":162,"_33":34,"_35":359,"_23":24,"_143":-5,"_263":360,"_26":361},{"_42":348,"_31":349,"_29":350,"_138":154,"_40":41,"_39":272,"_140":58,"_37":351,"_13":162,"_33":34,"_35":352,"_23":24,"_143":-5,"_263":353,"_26":354},{"_42":341,"_31":342,"_29":343,"_138":154,"_40":41,"_39":272,"_140":58,"_37":344,"_13":162,"_33":288,"_35":345,"_23":24,"_143":-5,"_263":346,"_26":347},{"_42":334,"_31":335,"_29":336,"_138":154,"_40":41,"_39":272,"_140":58,"_37":337,"_13":162,"_33":288,"_35":338,"_23":24,"_143":-5,"_263":339,"_26":340},{"_42":327,"_31":328,"_29":329,"_138":154,"_40":41,"_39":272,"_140":58,"_37":330,"_13":162,"_33":288,"_35":331,"_23":24,"_143":-5,"_263":332,"_26":333},{"_42":320,"_31":321,"_29":322,"_138":154,"_40":41,"_39":272,"_140":58,"_37":323,"_13":162,"_33":288,"_35":324,"_23":24,"_143":-5,"_263":325,"_26":326},{"_42":313,"_31":314,"_29":315,"_138":154,"_40":41,"_39":272,"_140":58,"_37":316,"_13":162,"_33":34,"_35":317,"_23":24,"_143":-5,"_263":318,"_26":319},{"_42":306,"_31":307,"_29":308,"_138":154,"_40":41,"_39":272,"_140":58,"_37":309,"_13":162,"_33":288,"_35":310,"_23":24,"_143":-5,"_263":311,"_26":312},{"_42":299,"_31":300,"_29":301,"_138":154,"_40":41,"_39":272,"_140":58,"_37":302,"_13":162,"_33":288,"_35":303,"_23":24,"_143":-5,"_263":304,"_26":305},{"_42":292,"_31":293,"_29":294,"_138":154,"_40":41,"_39":272,"_140":58,"_37":295,"_13":162,"_33":288,"_35":296,"_23":24,"_143":-5,"_263":297,"_26":298},{"_42":284,"_31":285,"_29":286,"_138":154,"_40":41,"_39":272,"_140":58,"_37":287,"_13":162,"_33":288,"_35":289,"_23":24,"_143":-5,"_263":290,"_26":291},{"_42":277,"_31":278,"_29":279,"_138":154,"_40":41,"_39":272,"_140":58,"_37":280,"_13":162,"_33":34,"_35":281,"_23":24,"_143":-5,"_263":282,"_26":283},{"_42":269,"_31":270,"_29":271,"_138":154,"_40":41,"_39":272,"_140":58,"_37":273,"_13":162,"_33":34,"_35":274,"_23":24,"_143":-5,"_263":275,"_26":276},{"_42":145,"_31":146,"_29":147,"_138":-5,"_40":41,"_39":148,"_140":58,"_37":266,"_13":62,"_33":34,"_35":150,"_23":24,"_143":-5,"_263":267,"_26":268},{"_42":135,"_31":136,"_29":137,"_138":-5,"_40":41,"_39":139,"_140":58,"_37":262,"_13":62,"_33":34,"_35":142,"_23":24,"_143":-5,"_263":264,"_26":265},["D",1788792128614],"children",[],[136],["D",1788792274049],[],[146],"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}",[],[153,270],"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}",[],[153,278],"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}",[],[153,285],"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}",[],[153,300],"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}",[],[153,307],"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}",[],[153,314],"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}",[],[153,321],"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}",[],[153,328],"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}",[],[153,335],"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}",[],[153,342],"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}",[],[153,349],"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}",[],[153,356],"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}",[],[153,363],"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(\",\"));",[],[153,370],"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}",[],[153,377],"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(\",\"));",[],[153,384],"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\");",[],[153,391],"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(\",\"));",[],[153,398],"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}",[],[153,405],"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}",[],[153,412],"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}",[],[153,419],"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(\",\"));",[],[153,426],"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));",[],[153,433],"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));",[],[153,440],"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}",[],[153,447],"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",[],[153,454],"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",[],[153,461],"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",[],[153,468],"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",[],[153,475],"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",[],[153,482],"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",[],[153,489],"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(\",\"));",[],[153,496],"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",[],[153,503],"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",[],[153,510],"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",[],[153,517],["D",1788778427608],[224,225,226,227,228,229,230,231,232,233,234,235,236,237,238,239,240,241,242,243,244,245,246,247,248,249,250,251,252,253,254,255,256,257,258,259],[153],"b4fb838e-ad28-4685-905d-b20694394de3","01a07b80-917a-70c9-9bdd-724f11870340",3,["D",1788791970521],[],[160,270],"9710492f-10e8-41e6-94f5-7b68cb51eff4","01a07b80-917a-70c9-9bdd-6fdbcf56575a",["D",1788791970521],[],[160,278],"97d2b498-3620-4ead-beee-165fa6103737",["D",1788791970521],[],[160,285],"c551bde9-702d-48d6-950c-479a0257040c","01a07b80-917a-70c9-9bdd-78afce09cb19",["D",1788791970521],[],[160,293],"97d4a3da-a9f1-45ce-b3bb-5d6cae672a9c","01a07b80-917a-70c9-9bdd-7d4a1f990d65",["D",1788791970521],[],[160,300],"1de64f76-baaa-4455-b8cd-88852f4c3033","01a07b80-917a-70c9-9bdd-842e3b1af7dd",["D",1788791970521],[],[160,307],"30bae13f-3c70-4eff-bd10-e4338af17a87","01a07b80-917a-70c9-9bdd-833574708179",["D",1788791970521],[],[160,314],"effd3f9c-d81f-44dc-99b6-827d8d71093e","01a07b80-917a-70c9-9bdd-892061b47c6a",["D",1788791970521],[],[160,321],"c43705fa-de3b-40af-a30d-918fe5624d8c","01a07b80-917b-72fb-80d5-523a7f2a9f01",["D",1788791970521],[],[160,328],"d93ee375-8547-472d-b2b0-3aa7ca5bcbe3","01a07b80-917b-72fb-80d5-55f3ed61311d",["D",1788791970521],[],[160,335],"f313bc99-a1e4-4120-90eb-4fb150d91f2d","01a07b80-917e-7744-959e-df520536a03f",["D",1788791970521],[],[160,342],"a81781b4-5703-4a96-9ec3-2bfd82d0bd31","01a07b80-917e-7744-959e-d9b97df48478",["D",1788791970521],[],[160,349],"b04c7845-bc79-44a3-b8d7-b8ee4d0c7346","01a07b80-917e-7744-959e-e3057e327a5c",["D",1788791970521],[],[160,356],"fc5066b7-a472-4eb4-8fbd-4c909005263b","01a07b80-917e-7744-959e-ee13af96d331",["D",1788791970521],[],[160,363],"a0e07c77-0412-49fb-9c7c-ab019322bc51","01a07b80-917e-7744-959e-f19fe1d19318",["D",1788791970521],[],[160,370],"ca3a72f5-b177-4adf-ab2a-967f276baf58","01a07b80-917e-7744-959e-f6eec71bc018",["D",1788791970521],[],[160,377],"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;",[],[160,607],"2aa3cf38-9cc1-4ed5-8e8b-4e8a50712bdd","01a07b80-917e-7744-959e-fef94aeaec83",["D",1788791970521],[],[160,384],"09b39cda-4ca2-435d-8250-cf0674705242","01a07b80-917e-7744-959f-02a2238e31e2",["D",1788791970521],[],[160,391],"f75761b9-b5c7-4175-8a7f-18e575507287","01a07b80-917e-7744-959f-0402a1cf7484",["D",1788791970521],[],[160,398],"27e9be76-0186-4c89-87ce-1f748fa14ed0","01a07b80-917e-7744-959f-0e98dd7b255f",["D",1788791970521],[],[160,405],"ce84cbf3-3aa6-4a45-82ee-ff8982ba22b9","01a07b80-917e-7744-959f-09706b876045",["D",1788791970521],[],[160,412],"1f9ccca2-0268-4093-9316-1cd9211fba12","01a07b80-917e-7744-959f-1046735b8ad3",["D",1788791970521],[],[160,419],"754e647a-63c3-4314-b5c2-029f2b25d714","01a07b80-917e-7744-959f-171bbb357d0a",["D",1788791970521],[],[160,426],"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};",[],[160,649],"368cf550-c01e-476a-a9ae-5f0d007a6248","01a07b80-917e-7744-959f-1f41b8dcb7d8",["D",1788791970521],[],[160,433],"e04d8f74-7ec3-41ad-ba40-f47bc39a327e","01a07b80-917e-7744-959f-23253ce6ab7a",["D",1788791970521],[],[160,440],"1af9bee8-5b0f-4d71-8d2d-b4179e994ee6","01a07b80-917e-7744-959f-251717844a5f",["D",1788791970521],[],[160,447],"89e0d6f9-a65e-4462-ac76-2c63a8e4385a","01a07b80-917e-7744-959f-2f42dcb55c76",["D",1788791970521],[],[160,454],"fa0b3726-3bf3-4f64-9e41-1085c951f0b0","01a07b80-917e-7744-959f-31f8f0930f3e",["D",1788791970521],[],[160,461],"7aeb770e-7243-487d-80de-26566c7f0126","01a07b80-917e-7744-959f-36aeefb05fbd",["D",1788791970521],[],[160,468],"29fcae84-a480-4c08-9eba-ae1616419270","01a07b80-917e-7744-959f-3e406ced83dc",["D",1788791970521],[],[160,475],"b23d60f4-697b-4d76-b8f7-0cbeed2a6349","01a07b80-917e-7744-959f-38b4d9234243",["D",1788791970521],[],[160,482],"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",[],[160,489],"40389488-b97c-487e-9e0a-841647a64bd1","01a07b80-917e-7744-959f-46294fef913c",["D",1788791970521],[],[160,496],"bf6200a3-bd3a-4a0a-ba36-8e483bf7e457","01a07b80-917e-7744-959e-e6e99069eb82",["D",1788791970521],[],[160,503],"3a77830b-9dd5-4051-a84e-01ea88fc175c","01a07b80-917e-7744-959e-e8df0b1de1d4",["D",1788791970521],[],[160,510],"379f18c7-2bf0-4c6e-918e-a56197444246","01a07b80-917e-7744-959f-2ba3b7809787",["D",1788791970521],[],[160,517],["D",1788778418560],[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],[160],"a84ec2a8-e6b7-442c-8d38-6226840c23d8","current_brain_bridge_worker.ts","01a07c7e-6745-721c-8140-4c3e06a9dae9",["D",1788795053895],"import { API_URL } from \"https://esm.town/v/std/API_URL\";\nimport { createClient } from \"npm:@libsql/client@0.17.2/web\";\n\nconst scopedToken=Deno.env.get(\"VAL_TOWN_API_KEY\")||\"\";\nconst nativeFetch=async(input:any,init?:any):Promise=>{\n if(typeof input===\"string\" || input instanceof URL) return await globalThis.fetch(input,init);\n const method=String(input?.method||init?.method||\"GET\");\n const headers=new Headers();\n const src=input?.headers||init?.headers;\n if(src?.forEach) src.forEach((v:string,k:string)=>headers.set(k,v));\n else if(src) for(const [k,v] of Object.entries(src)) headers.set(k,String(v));\n let body:any=undefined;\n if(method!==\"GET\" && method!==\"HEAD\"){\n if(typeof input?.arrayBuffer===\"function\") body=new Uint8Array(await input.arrayBuffer());\n else body=input?.body??init?.body;\n }\n return await globalThis.fetch(String(input.url),{method,headers,body,redirect:\"manual\"});\n};\nconst sqlite:any=createClient({url:`${API_URL}/v3/sqlite/scoped/`,authToken:scopedToken,fetch:nativeFetch});\nimport { prepareAdmissionAwareCoalescePlan as prepareAtomicCoalescePlan } from \"./brain_bridge_readonly_coalesce_admission_v1.ts\";\nimport { AUTHORITY_TABLE, ensureAuthorityTable } from \"./brain_bridge_authority_epoch_v1.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 \"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){\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='FAILED',\n result_json=NULL,\n error_json=json_object(\n 'classification','TRANSPORT_LEASE_EXPIRED_OUTCOME_UNKNOWN',\n 'retry_policy','RECONCILE_CANONICAL_STATE_THEN_NEW_JOB_ID'\n ),\n lease_owner=NULL,\n lease_expires_at=NULL,\n 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\n CASE\n WHEN j.op='brain' AND json_valid(j.payload_json)=1 THEN\n CASE\n WHEN json_type(j.payload_json,'$.args')='array'\n AND json_array_length(json_extract(j.payload_json,'$.args'))=1\n AND json_extract(j.payload_json,'$.args[0]')='recover-stale'\n AND json_type(j.payload_json,'$.timeout')='integer'\n AND json_extract(j.payload_json,'$.timeout') BETWEEN 1 AND ${MAX_JOB_TIMEOUT}\n AND (SELECT COUNT(*) FROM json_each(j.payload_json))=2\n THEN 0 ELSE 1\n END\n ELSE 1\n END ASC,\n CASE\n WHEN j.op='brain' AND json_valid(j.payload_json)=1\n AND json_type(j.payload_json,'$.args')='array'\n AND (\n (\n json_array_length(json_extract(j.payload_json,'$.args'))=1\n AND json_extract(j.payload_json,'$.args[0]') IN ('status','verify-chain','verify-claim-graph')\n AND json_type(j.payload_json,'$.timeout')='integer'\n AND json_extract(j.payload_json,'$.timeout') BETWEEN 1 AND ${MAX_JOB_TIMEOUT}\n AND (SELECT COUNT(*) FROM json_each(j.payload_json))=2\n )\n OR json_extract(j.payload_json,'$.args[0]') IN ('register-agent','claim')\n )\n THEN 0 ELSE 1\n END ASC,\n CASE\n WHEN j.op='brain'\n AND json_valid(j.payload_json)=1\n AND json_extract(j.payload_json,'$.args[0]')='claim'\n AND json_extract(j.payload_json,'$.args[1]')='--agent'\n AND EXISTS(\n SELECT 1 FROM ${table} r\n WHERE r.state='READY'\n AND r.op='brain'\n AND json_valid(r.payload_json)=1\n AND json_extract(r.payload_json,'$.args[0]')='register-agent'\n AND json_extract(r.payload_json,'$.args[1]')=json_extract(j.payload_json,'$.args[2]')\n AND r.created_at=j.created_at\n )\n THEN 1 ELSE 0\n END ASC,\n CASE WHEN j.priority > ${PRIORITY_CAP} THEN ${PRIORITY_CAP} ELSE j.priority END DESC,\n j.created_at,\n CASE\n WHEN j.op='brain' AND json_valid(j.payload_json)=1\n AND json_extract(j.payload_json,'$.args[0]')='status' THEN 0\n WHEN j.op='brain' AND json_valid(j.payload_json)=1\n AND json_extract(j.payload_json,'$.args[0]')='verify-chain' THEN 1\n WHEN j.op='brain' AND json_valid(j.payload_json)=1\n AND json_extract(j.payload_json,'$.args[0]')='verify-claim-graph' THEN 2\n WHEN j.op='brain' AND json_valid(j.payload_json)=1\n AND json_extract(j.payload_json,'$.args[0]')='register-agent' THEN 3\n WHEN j.op='brain' AND json_valid(j.payload_json)=1\n AND json_extract(j.payload_json,'$.args[0]')='claim' THEN 4\n ELSE 5\n END ASC,\n j.rowid,\n 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([\"status\",\"verify-chain\",\"verify-claim-graph\"].includes(cmd) && q.args.length!==1){\n return {ok:false,error:\"READ_ONLY_COMMAND_ARGS_FORBIDDEN\"};\n }\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:\"BOOT_AGENT_NOT_END_TO_END_USE_REGISTER_AGENT_THEN_CLAIM\"};\n if(cmd===\"renew-lease\" && q.args.includes(\"--lease-seconds\")){\n return {ok:false,error:\"RENEW_LEASE_USE_SECONDS_NOT_LEASE_SECONDS\"};\n }\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\nlet schemaReady:Promise|null=null;\nasync function ensureTables(){\n if(!schemaReady){\n schemaReady=(async()=>{\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 await ensureAuthorityTable(sqlite);\n })();\n }\n try{await schemaReady}catch(e){schemaReady=null;throw e}\n}\nasync function admitHostWriter(){\n await ensureTables();\n const r:any=await sqlite.execute(`SELECT epoch,writer,source_generation,source_head,mode,prepared_at,updated_at FROM ${AUTHORITY_TABLE} WHERE id=1`);\n const a:any=r.rows?.[0]||null;\n if(!a)return {ok:false,reason:\"AUTHORITY_UNINITIALIZED\"};\n if(String(a.mode)!==\"ACTIVE\")return {ok:false,reason:\"AUTHORITY_PREPARED_NO_WRITER\",authority:a};\n if(String(a.writer)!==\"host_bridge\")return {ok:false,reason:\"WRITER_NOT_CANONICAL\",authority:a};\n return {ok:true,epoch:Number(a.epoch),authority:a};\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,qc,dup,auth,dur]:any[]=await sqlite.batch([\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 brain_bridge_workers_v4\n ORDER BY last_poll_at DESC LIMIT 1`},\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`,args:[PRIORITY_CAP]},\n {sql:`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 {sql:`SELECT epoch,writer,source_generation,source_head,mode,prepared_at,updated_at\n FROM ${AUTHORITY_TABLE} WHERE id=1`},\n {sql:`SELECT\n (SELECT generation FROM brainvn_epoch_meta WHERE id=1) AS canonical_generation,\n (SELECT MAX(generation) FROM brainvn_replicas WHERE verified=1) AS max_verified_replica_generation,\n (SELECT COUNT(*) FROM brainvn_replicas WHERE verified=1) AS verified_replica_count`}\n ],\"read\");\n const w=wr.rows?.[0]||null;\n const q=qc.rows?.[0]||{};\n const a=auth.rows?.[0]||null;\n const d=dur.rows?.[0]||{};\n const canonicalGeneration=d.canonical_generation==null?null:Number(d.canonical_generation);\n const maxVerifiedReplicaGeneration=d.max_verified_replica_generation==null?null:Number(d.max_verified_replica_generation);\n const durabilityLagGenerations=\n canonicalGeneration==null||maxVerifiedReplicaGeneration==null\n ? null\n : Math.max(0,canonicalGeneration-maxVerifiedReplicaGeneration);\n const durabilityState=\n durabilityLagGenerations==null ? \"UNKNOWN\" :\n durabilityLagGenerations===0 ? \"CURRENT\" : \"LAGGING\";\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-boot-cohort-fair-v1\",\n control_plane_authority:a,\n worker:w,\n worker_state:cls.state,\n worker_reason:cls.reason,\n worker_health_scope:\"HOST_BRIDGE_WORKER_ONLY\",\n instance_identity_available:w ? w.instance_id!==\"LEGACY_UNATTESTED_INSTANCE\" : false,\n duplicate_active_worker_leases:duplicateActiveLeases,\n queue:q,\n durability:{\n canonical_generation:canonicalGeneration,\n max_verified_replica_generation:maxVerifiedReplicaGeneration,\n verified_replica_count:Number(d.verified_replica_count||0),\n lag_generations:durabilityLagGenerations,\n state:durabilityState\n },\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_BOOT_COHORT_PAIRED_REGISTER_BEFORE_CLAIM_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 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 authority=await admitHostWriter();\n if(!authority.ok)return json({ok:false,error:\"CONTROL_PLANE_WRITER_FENCED\",reason:authority.reason,authority:authority.authority??null},409);\n const instance=instanceOf(q);\n const pollBatch:any[]=await sqlite.batch([\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')`,args:[worker,instance]},\n {sql:recoverExpiredSql()},\n {sql:activeLeaseSql(),args:[worker]},\n {sql:leaseOneSql(),args:[worker,worker]}\n ],\"write\");\n const ar:any=pollBatch[2];\n const r:any=pollBatch[3];\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 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 authority=await admitHostWriter();\n if(!authority.ok)return json({ok:false,error:\"CONTROL_PLANE_RESULT_FENCED\",reason:authority.reason,authority:authority.authority??null},409);\n\n const resultJson=success?JSON.stringify(q.result??null):null;\n const plan=success&&resultJson ? prepareAtomicCoalescePlan(resultJson,id,worker,true) : null;\n let state:string;\n let coalescedIds:string[]=[];\n\n if(plan){\n const cr:any=await sqlite.execute({sql:plan.sql,args:plan.args});\n const ids=(cr.rows||[]).map((x:any)=>String(x.id));\n if(!ids.includes(id))return json({ok:false,error:\"LEASE_MISMATCH_OR_EXPIRED\"},409);\n state=\"COMPLETE\";\n coalescedIds=ids.filter((x:string)=>x!==id);\n }else{\n const r:any=await sqlite.execute({\n sql:resultSql(),\n args:[success?\"COMPLETE\":\"FAILED\",resultJson,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 state=String(r.rows[0].state);\n }\n\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,worker_id:worker,instance_id:instance,\n coalesced_count:coalescedIds.length,coalesced_ids:coalescedIds});\n }\n return json({ok:false,error:\"NOT_FOUND\"},404);\n}\n",[],[166,725],"7b2e473f-89b3-490b-8153-47d7b0320b18",["D",1788795055718],[],[166,32],["D",1788795053895],[182,183],[166],["D",1788778403598],["D",1789477862254],{"_99":98,"_107":103},{"_99":98,"_100":101,"_102":103,"_18":54,"_104":105,"_106":24},{"_13":88,"_31":89,"_42":41,"_90":43,"_91":-5,"_92":-5,"_93":-5,"_94":-5,"_95":-5,"_96":44,"_97":98},"ctx",{"_81":-5,"_127":776,"_777":778,"_779":780,"_781":24,"_782":24,"_783":24,"_784":58,"_785":-5,"_786":-7,"_787":-7,"_788":62,"_789":24,"_790":24,"_791":-5,"_792":24,"_793":24,"_794":24,"_795":-5},"ENV",{"_747":748,"_749":750,"_751":89,"_752":753,"_754":755,"_756":757,"_758":759,"_760":761,"_762":763,"_764":765,"_766":767,"_768":769,"_770":771,"_772":773,"_774":775},"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 · v8