[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_300":301,"_302":303},"routes/_app.x.$handle.$name",{"_100":99,"_32":45,"_109":90,"_27":110,"_13":14,"_111":-5,"_11":112,"_113":114,"_115":116,"_117":118,"_119":120,"_20":-5,"_121":-5,"_122":-5,"_123":25,"_124":125,"_126":59,"_127":-5,"_128":-5,"_129":130},"routes/_app.x.$handle.$name.branch.$branch.version.$version.diff",{"_11":12,"_13":14,"_15":16,"_17":-5,"_18":-5},"project",{"_43":44,"_32":45,"_38":46,"_47":-5,"_48":25,"_49":50,"_51":50,"_52":53,"_54":-5,"_18":55,"_56":57,"_58":59,"_60":-5,"_61":-5,"_62":63,"_64":65,"_66":67,"_68":69,"_70":71,"_72":-5,"_73":74,"_75":74,"_76":77,"_78":77,"_79":77,"_80":74,"_81":74,"_82":83,"_84":85,"_86":87,"_88":25},"version",12,"changes",[19],"aiChatInfo","userId",{"_20":21,"_22":23,"_24":25,"_26":25,"_27":28,"_29":28},"file",{"_30":31,"_32":28,"_33":34,"_35":37,"_38":39,"_40":14,"_41":42,"_24":25},"previous",{"_30":31,"_32":28,"_33":34,"_35":36},"deleted",false,"deletedHere","path","coalesce_v2_regression_test.ts","latestPath","fileId","b46196a6-a997-11f1-adb7-1607ee4eb77e","name","fileType","script","content","import { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\nimport { coalesceFollowersSql, mayCoalesceSuccessfulLeader, validReadonlyResultEnvelope } from \"./brain_bridge_readonly_coalesce_v2_candidate.ts\";\nimport { resultSql } from \"./brain_bridge_worker.ts\";\n\ntype Check={name:string;pass:boolean;detail?:unknown};\nconst checks:Check[]=[];\nconst check=(name:string,pass:boolean,detail?:unknown)=>checks.push({name,pass,detail});\nconst T=\"brain_bridge_coalesce_v2_reg_\"+crypto.randomUUID().replaceAll(\"-\",\"\");\nconst read=JSON.stringify({args:[\"verify-chain\"],timeout:60});\nconst status=JSON.stringify({args:[\"status\"],timeout:60});\nconst mutate=JSON.stringify({args:[\"commit\",\"--agent\",\"a\"],timeout:60});\nconst recover=JSON.stringify({args:[\"recover-stale\"],timeout:60});\nconst good=JSON.stringify({returncode:0,stdout:'{\"ok\":true}\\\\n',stderr:\"\",stdout_truncated:false,stderr_truncated:false});\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, state TEXT NOT NULL,\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)`);\nasync function reset(){await sqlite.execute(`DELETE FROM ${T}`)}\nasync function ins(id:string,priority:number,op:string,payload:string,state:string,owner:string|null,expires:string|null,created:string,updated:string){\n await sqlite.execute({sql:`INSERT INTO ${T}(id,priority,op,payload_json,state,lease_owner,lease_expires_at,created_at,updated_at)\n VALUES(?,?,?,?,?,?,?,?,?)`,args:[id,priority,op,payload,state,owner,expires,created,updated]});\n}\nasync function row(id:string){return (await sqlite.execute({sql:`SELECT * FROM ${T} WHERE id=?`,args:[id]})).rows?.[0] as any}\nasync function fan(result:string,leader:any){\n const r:any=await sqlite.execute({sql:coalesceFollowersSql(T),args:[result,leader.op,leader.payload_json,leader.leased_at]});\n return (r.rows||[]).map((x:any)=>String(x.id)).sort();\n}\nasync function basicLeaderFollower(followerPriority=100){\n await ins(\"leader\",100,\"brain\",read,\"LEASED\",\"w\",\"2099-01-01 00:00:00\",\"2026-01-01 00:00:01\",\"2026-01-01 00:00:10\");\n await ins(\"follower\",followerPriority,\"brain\",read,\"READY\",null,null,\"2026-01-01 00:00:06\",\"2026-01-01 00:00:06\");\n return {...(await row(\"leader\")),leased_at:\"2026-01-01 00:00:10\"};\n}\ntry{\n check(\"valid_envelope\",validReadonlyResultEnvelope(good));\n const invalids:[string,unknown][]=[\n [\"null\",\"null\"],\n [\"malformed\",\"{\"],\n [\"extra\",JSON.stringify({returncode:0,stdout:\"x\",stderr:\"\",stdout_truncated:false,stderr_truncated:false,extra:1})],\n [\"missing_flag\",JSON.stringify({returncode:0,stdout:\"x\",stderr:\"\",stdout_truncated:false})],\n [\"nonzero\",JSON.stringify({returncode:1,stdout:\"x\",stderr:\"\",stdout_truncated:false,stderr_truncated:false})],\n [\"stdout_truncated\",JSON.stringify({returncode:0,stdout:\"x\",stderr:\"\",stdout_truncated:true,stderr_truncated:false})],\n [\"stderr_truncated\",JSON.stringify({returncode:0,stdout:\"x\",stderr:\"\",stdout_truncated:false,stderr_truncated:true})]\n ];\n for(const [name,v] of invalids) check(\"reject_\"+name,!validReadonlyResultEnvelope(String(v)),v);\n\n for(const [name,result] of invalids){\n await reset(); const leader=await basicLeaderFollower();\n const ids=await fan(String(result),leader);\n check(\"sql_reject_\"+name,ids.length===0 && (await row(\"follower\")).state===\"READY\",{ids});\n }\n\n await reset();\n let leader=await basicLeaderFollower();\n await ins(\"mutation\",100,\"brain\",mutate,\"READY\",null,null,\"2026-01-01 00:00:05\",\"2026-01-01 00:00:05\");\n check(\"same_priority_mutation_barrier\",(await fan(good,leader)).length===0);\n\n await reset();\n leader=await basicLeaderFollower();\n await ins(\"higher_later_mutation\",101,\"brain\",mutate,\"READY\",null,null,\"2026-01-01 00:00:20\",\"2026-01-01 00:00:20\");\n check(\"higher_priority_later_mutation_barrier\",(await fan(good,leader)).length===0);\n\n await reset();\n leader=await basicLeaderFollower();\n await ins(\"recover\",0,\"brain\",recover,\"READY\",null,null,\"2026-01-01 00:00:20\",\"2026-01-01 00:00:20\");\n check(\"recover_stale_rank_zero_barrier\",(await fan(good,leader)).length===0);\n\n await reset();\n await ins(\"leader\",100,\"brain\",read,\"LEASED\",\"w\",\"2099-01-01 00:00:00\",\"2026-01-01 00:00:01\",\"2026-01-01 00:00:10\");\n await ins(\"mutation-a\",100,\"brain\",mutate,\"READY\",null,null,\"2026-01-01 00:00:06\",\"2026-01-01 00:00:06\");\n await ins(\"follower-z\",100,\"brain\",read,\"READY\",null,null,\"2026-01-01 00:00:06\",\"2026-01-01 00:00:06\");\n leader={...(await row(\"leader\")),leased_at:\"2026-01-01 00:00:10\"};\n check(\"same_timestamp_id_mutation_barrier\",(await fan(good,leader)).length===0);\n\n await reset();\n leader=await basicLeaderFollower(100);\n await ins(\"lower_mutation\",99,\"brain\",mutate,\"READY\",null,null,\"2026-01-01 00:00:02\",\"2026-01-01 00:00:02\");\n const lowerIds=await fan(good,leader);\n check(\"lower_priority_mutation_not_barrier\",JSON.stringify(lowerIds)===JSON.stringify([\"follower\"]),lowerIds);\n\n await reset();\n leader=await basicLeaderFollower(100);\n await ins(\"readonly_between\",100,\"brain\",status,\"READY\",null,null,\"2026-01-01 00:00:05\",\"2026-01-01 00:00:05\");\n const roIds=await fan(good,leader);\n check(\"readonly_boot_job_not_mutation_barrier\",JSON.stringify(roIds)===JSON.stringify([\"follower\"]),roIds);\n\n await reset();\n await ins(\"leader\",100,\"brain\",read,\"LEASED\",\"w\",\"2099-01-01 00:00:00\",\"2026-01-01 00:00:01\",new Date().toISOString().replace(\"T\",\" \").slice(0,19));\n await ins(\"follower\",100,\"brain\",read,\"READY\",null,null,\"2026-01-01 00:00:02\",\"2026-01-01 00:00:02\");\n leader={...(await row(\"leader\")),leased_at:\"2099-01-01 00:00:00\"};\n const resultText=good;\n const rr1:any=await sqlite.execute({sql:resultSql(T),args:[\"COMPLETE\",resultText,null,\"leader\",\"w\"]});\n let ids1:string[]=[];\n if(rr1.rows?.length && mayCoalesceSuccessfulLeader(leader,true,\"w\")) ids1=await fan(resultText,leader);\n const rr2:any=await sqlite.execute({sql:resultSql(T),args:[\"COMPLETE\",resultText,null,\"leader\",\"w\"]});\n let ids2:string[]=[];\n if(rr2.rows?.length && mayCoalesceSuccessfulLeader(leader,true,\"w\")) ids2=await fan(resultText,leader);\n check(\"stale_result_aba_resultsql_fences_replay\",rr1.rows?.length===1 && ids1.includes(\"follower\") && rr2.rows?.length===0 && ids2.length===0,{rr1:rr1.rows?.length,ids1,rr2:rr2.rows?.length,ids2});\n\n const expired={id:\"e\",state:\"LEASED\",lease_owner:\"w\",lease_expires_at:\"2026-01-01 00:00:00\",op:\"brain\",payload_json:read,leased_at:\"2026-01-01 00:00:00\"};\n check(\"helper_rejects_expired_leader\",!mayCoalesceSuccessfulLeader(expired,true,\"w\"));\n\n const failed=checks.filter(x=>!x.pass);\n console.log(JSON.stringify({ok:failed.length===0,classification:failed.length?\"READONLY_V2_REGRESSION_FAIL\":\"READONLY_V2_REGRESSION_PASS\",checks:checks.length,passed:checks.length-failed.length,failed:failed.length,failures:failed},null,2));\n if(failed.length) throw new Error(\"V2_REGRESSION_FAILURES=\"+failed.map(x=>x.name).join(\",\"));\n} finally { await sqlite.execute(`DROP TABLE IF EXISTS ${T}`); }","import { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\nimport { coalesceFollowersSql, mayCoalesceSuccessfulLeader, validReadonlyResultEnvelope } from \"./brain_bridge_readonly_coalesce_v2_candidate.ts\";\nimport { resultSql } from \"./brain_bridge_worker.ts\";\n\ntype Check={name:string;pass:boolean;detail?:unknown};\nconst checks:Check[]=[];\nconst check=(name:string,pass:boolean,detail?:unknown)=>checks.push({name,pass,detail});\nconst T=\"brain_bridge_coalesce_v2_reg_\"+crypto.randomUUID().replaceAll(\"-\",\"\");\nconst read=JSON.stringify({args:[\"verify-chain\"],timeout:60});\nconst status=JSON.stringify({args:[\"status\"],timeout:60});\nconst mutate=JSON.stringify({args:[\"commit\",\"--agent\",\"a\"],timeout:60});\nconst recover=JSON.stringify({args:[\"recover-stale\"],timeout:60});\nconst good=JSON.stringify({returncode:0,stdout:'{\"ok\":true}\\\\n',stderr:\"\",stdout_truncated:false,stderr_truncated:false});\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, state TEXT NOT NULL,\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)`);\nasync function reset(){await sqlite.execute(`DELETE FROM ${T}`)}\nasync function ins(id:string,priority:number,op:string,payload:string,state:string,owner:string|null,expires:string|null,created:string,updated:string){\n await sqlite.execute({sql:`INSERT INTO ${T}(id,priority,op,payload_json,state,lease_owner,lease_expires_at,created_at,updated_at)\n VALUES(?,?,?,?,?,?,?,?,?)`,args:[id,priority,op,payload,state,owner,expires,created,updated]});\n}\nasync function row(id:string){return (await sqlite.execute({sql:`SELECT * FROM ${T} WHERE id=?`,args:[id]})).rows?.[0] as any}\nasync function fan(result:string,leader:any){\n const r:any=await sqlite.execute({sql:coalesceFollowersSql(T),args:[result,leader.op,leader.payload_json,leader.leased_at]});\n return (r.rows||[]).map((x:any)=>String(x.id)).sort();\n}\nasync function basicLeaderFollower(followerPriority=100){\n await ins(\"leader\",100,\"brain\",read,\"LEASED\",\"w\",\"2099-01-01 00:00:00\",\"2026-01-01 00:00:01\",\"2026-01-01 00:00:10\");\n await ins(\"follower\",followerPriority,\"brain\",read,\"READY\",null,null,\"2026-01-01 00:00:06\",\"2026-01-01 00:00:06\");\n return {...(await row(\"leader\")),leased_at:\"2026-01-01 00:00:10\"};\n}\ntry{\n check(\"valid_envelope\",validReadonlyResultEnvelope(good));\n const invalids:[string,unknown][]=[\n [\"null\",\"null\"],\n [\"malformed\",\"{\"],\n [\"extra\",JSON.stringify({returncode:0,stdout:\"x\",stderr:\"\",stdout_truncated:false,stderr_truncated:false,extra:1})],\n [\"missing_flag\",JSON.stringify({returncode:0,stdout:\"x\",stderr:\"\",stdout_truncated:false})],\n [\"nonzero\",JSON.stringify({returncode:1,stdout:\"x\",stderr:\"\",stdout_truncated:false,stderr_truncated:false})],\n [\"stdout_truncated\",JSON.stringify({returncode:0,stdout:\"x\",stderr:\"\",stdout_truncated:true,stderr_truncated:false})],\n [\"stderr_truncated\",JSON.stringify({returncode:0,stdout:\"x\",stderr:\"\",stdout_truncated:false,stderr_truncated:true})]\n ];\n for(const [name,v] of invalids) check(\"reject_\"+name,!validReadonlyResultEnvelope(String(v)),v);\n\n for(const [name,result] of invalids){\n await reset(); const leader=await basicLeaderFollower();\n const ids=await fan(String(result),leader);\n check(\"sql_reject_\"+name,ids.length===0 && (await row(\"follower\")).state===\"READY\",{ids});\n }\n\n await reset();\n let leader=await basicLeaderFollower();\n await ins(\"mutation\",100,\"brain\",mutate,\"READY\",null,null,\"2026-01-01 00:00:05\",\"2026-01-01 00:00:05\");\n check(\"same_priority_mutation_barrier\",(await fan(good,leader)).length===0);\n\n await reset();\n leader=await basicLeaderFollower();\n await ins(\"higher_later_mutation\",101,\"brain\",mutate,\"READY\",null,null,\"2026-01-01 00:00:20\",\"2026-01-01 00:00:20\");\n check(\"higher_priority_later_mutation_barrier\",(await fan(good,leader)).length===0);\n\n await reset();\n leader=await basicLeaderFollower();\n await ins(\"recover\",0,\"brain\",recover,\"READY\",null,null,\"2026-01-01 00:00:20\",\"2026-01-01 00:00:20\");\n check(\"recover_stale_rank_zero_barrier\",(await fan(good,leader)).length===0);\n\n await reset();\n await ins(\"leader\",100,\"brain\",read,\"LEASED\",\"w\",\"2099-01-01 00:00:00\",\"2026-01-01 00:00:01\",\"2026-01-01 00:00:10\");\n await ins(\"a-mutation\",100,\"brain\",mutate,\"READY\",null,null,\"2026-01-01 00:00:06\",\"2026-01-01 00:00:06\");\n await ins(\"z-follower\",100,\"brain\",read,\"READY\",null,null,\"2026-01-01 00:00:06\",\"2026-01-01 00:00:06\");\n leader={...(await row(\"leader\")),leased_at:\"2026-01-01 00:00:10\"};\n check(\"same_timestamp_id_mutation_barrier\",(await fan(good,leader)).length===0);\n\n await reset();\n leader=await basicLeaderFollower(100);\n await ins(\"lower_mutation\",99,\"brain\",mutate,\"READY\",null,null,\"2026-01-01 00:00:02\",\"2026-01-01 00:00:02\");\n const lowerIds=await fan(good,leader);\n check(\"lower_priority_mutation_not_barrier\",JSON.stringify(lowerIds)===JSON.stringify([\"follower\"]),lowerIds);\n\n await reset();\n leader=await basicLeaderFollower(100);\n await ins(\"readonly_between\",100,\"brain\",status,\"READY\",null,null,\"2026-01-01 00:00:05\",\"2026-01-01 00:00:05\");\n const roIds=await fan(good,leader);\n check(\"readonly_boot_job_not_mutation_barrier\",JSON.stringify(roIds)===JSON.stringify([\"follower\"]),roIds);\n\n await reset();\n await ins(\"leader\",100,\"brain\",read,\"LEASED\",\"w\",\"2099-01-01 00:00:00\",\"2026-01-01 00:00:01\",new Date().toISOString().replace(\"T\",\" \").slice(0,19));\n await ins(\"follower\",100,\"brain\",read,\"READY\",null,null,\"2026-01-01 00:00:02\",\"2026-01-01 00:00:02\");\n leader={...(await row(\"leader\")),leased_at:\"2099-01-01 00:00:00\"};\n const resultText=good;\n const rr1:any=await sqlite.execute({sql:resultSql(T),args:[\"COMPLETE\",resultText,null,\"leader\",\"w\"]});\n let ids1:string[]=[];\n if(rr1.rows?.length && mayCoalesceSuccessfulLeader(leader,true,\"w\")) ids1=await fan(resultText,leader);\n const rr2:any=await sqlite.execute({sql:resultSql(T),args:[\"COMPLETE\",resultText,null,\"leader\",\"w\"]});\n let ids2:string[]=[];\n if(rr2.rows?.length && mayCoalesceSuccessfulLeader(leader,true,\"w\")) ids2=await fan(resultText,leader);\n check(\"stale_result_aba_resultsql_fences_replay\",rr1.rows?.length===1 && ids1.includes(\"follower\") && rr2.rows?.length===0 && ids2.length===0,{rr1:rr1.rows?.length,ids1,rr2:rr2.rows?.length,ids2});\n\n const expired={id:\"e\",state:\"LEASED\",lease_owner:\"w\",lease_expires_at:\"2026-01-01 00:00:00\",op:\"brain\",payload_json:read,leased_at:\"2026-01-01 00:00:00\"};\n check(\"helper_rejects_expired_leader\",!mayCoalesceSuccessfulLeader(expired,true,\"w\"));\n\n const failed=checks.filter(x=>!x.pass);\n console.log(JSON.stringify({ok:failed.length===0,classification:failed.length?\"READONLY_V2_REGRESSION_FAIL\":\"READONLY_V2_REGRESSION_PASS\",checks:checks.length,passed:checks.length-failed.length,failed:failed.length,failures:failed},null,2));\n if(failed.length) throw new Error(\"V2_REGRESSION_FAILURES=\"+failed.map(x=>x.name).join(\",\"));\n} finally { await sqlite.execute(`DROP TABLE IF EXISTS ${T}`); }","createdAt",["D",1788660555259],"branchVersion","branchId","35b679b8-79ea-4d07-a74e-db8f3bf6ce8b","id","c65dd86a-b37f-4be8-9316-7f775eeaf3a6","brain-coalesce-v2-a19c",["D",1788660201596],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","Isolated Brain coalescer V2 repair","imageUrl","6be0fc5c-1fef-4bd6-a1e1-67a3f8c0764e","pinnedFileId","01a07474-dd3d-76da-bd7c-0da81a631649","pinPreview",true,"pinMigrated","screenshotVersion","likeCount",0,"orgId","01a0715b-703f-741f-ab35-c85020e4a5e0","tursoName","c65dd86ab37f4be893167f775eeaf3a6","tursoHostname","c65dd86ab37f4be893167f775eeaf3a6-val-town.aws-us-east-2.turso.io","tursoMeasuredAt",["D",1789533091345],"pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_100":99,"_108":104},"org",{"_100":99,"_101":102,"_103":104,"_18":55,"_105":106,"_107":25},"branch",{"_13":89,"_32":90,"_43":42,"_91":44,"_92":-5,"_93":-5,"_94":-5,"_95":-5,"_96":-5,"_97":45,"_98":99},"isOwned",16,"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",{"_43":44,"_32":45,"_38":295,"_47":-5,"_48":25,"_49":50,"_51":50,"_52":53,"_54":-5,"_18":55,"_56":57,"_58":59,"_60":-5,"_61":-5,"_62":63,"_64":65,"_66":67,"_68":69,"_70":296,"_72":-5,"_73":74,"_75":74,"_76":77,"_78":77,"_79":77,"_80":74,"_81":74,"_82":297,"_84":298,"_86":299,"_88":25},"tree",[225,229,230,231,232,233,234,235,236,237,238],"files",[225,226,227,228,229,230,231,232,233,234,235,236,237,238],"counts",{"_215":63,"_216":146,"_217":63,"_218":219,"_220":221},"contents",[131,132,133,134,135,136,137,138,139,140,141],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},{"_43":208,"_32":209,"_30":210,"_143":-5,"_41":42,"_40":211,"_144":59,"_38":212,"_13":63,"_33":213,"_35":-5,"_24":25,"_147":-5,"_27":214},{"_43":202,"_32":203,"_30":204,"_143":-5,"_41":42,"_40":146,"_144":59,"_38":205,"_13":63,"_33":20,"_35":206,"_24":25,"_147":-5,"_27":207},{"_43":196,"_32":197,"_30":198,"_143":-5,"_41":42,"_40":192,"_144":59,"_38":199,"_13":63,"_33":34,"_35":200,"_24":25,"_147":-5,"_27":201},{"_43":189,"_32":190,"_30":191,"_143":-5,"_41":42,"_40":192,"_144":59,"_38":193,"_13":63,"_33":34,"_35":194,"_24":25,"_147":-5,"_27":195},{"_43":182,"_32":183,"_30":184,"_143":-5,"_41":42,"_40":185,"_144":59,"_38":186,"_13":63,"_33":34,"_35":187,"_24":25,"_147":-5,"_27":188},{"_43":175,"_32":176,"_30":177,"_143":-5,"_41":42,"_40":178,"_144":59,"_38":179,"_13":63,"_33":34,"_35":180,"_24":25,"_147":-5,"_27":181},{"_43":168,"_32":169,"_30":57,"_143":-5,"_41":42,"_40":170,"_144":59,"_38":171,"_13":63,"_33":172,"_35":173,"_24":25,"_147":-5,"_27":174},{"_43":162,"_32":163,"_30":164,"_143":-5,"_41":42,"_40":152,"_144":25,"_38":165,"_13":63,"_33":34,"_35":166,"_24":25,"_147":-5,"_27":167},{"_43":156,"_32":157,"_30":158,"_143":-5,"_41":42,"_40":152,"_144":25,"_38":159,"_13":63,"_33":34,"_35":160,"_24":25,"_147":-5,"_27":161},{"_43":149,"_32":150,"_30":151,"_143":-5,"_41":42,"_40":152,"_144":25,"_38":153,"_13":63,"_33":34,"_35":154,"_24":25,"_147":-5,"_27":155},{"_43":142,"_32":28,"_30":31,"_143":-5,"_41":42,"_40":14,"_144":59,"_38":145,"_13":146,"_33":34,"_35":37,"_24":25,"_147":-5,"_27":148},"7f5e8787-9e3e-4d5b-86b7-09983217a732","parentId","latest",["D",1788660555259],1,"label",[28],"636a5518-29ae-40f9-8c2c-b5a90db9f8da","coalesce_e72c_order_test.ts","01a07474-d845-763b-8ed2-493754878221",3,["D",1788660209734],"import { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\nimport { coalesceFollowersSql, mayCoalesceSuccessfulLeader } from \"./brain_bridge_readonly_coalesce_v1_candidate.ts\";\n\nconst T=\"coalesce_order_\"+crypto.randomUUID().replaceAll(\"-\",\"\");\nconst read=JSON.stringify({args:[\"verify-chain\"],timeout:60});\nconst mutation=JSON.stringify({args:[\"commit\",\"--agent\",\"a\"],timeout:60});\nawait sqlite.execute(`CREATE TABLE ${T}(\n id TEXT PRIMARY KEY, priority REAL, op TEXT, payload_json TEXT, state TEXT,\n lease_owner TEXT, lease_expires_at TEXT, result_json TEXT, error_json TEXT,\n created_at TEXT, updated_at TEXT)`);\ntry{\n const rows=[\n [\"leader\",100,\"brain\",read,\"LEASED\",\"w\",\"2026-01-01 00:03:10\",\"2026-01-01 00:00:01\",\"2026-01-01 00:00:10\"],\n [\"mutation\",100,\"brain\",mutation,\"READY\",null,null,\"2026-01-01 00:00:05\",\"2026-01-01 00:00:05\"],\n [\"follower\",100,\"brain\",read,\"READY\",null,null,\"2026-01-01 00:00:06\",\"2026-01-01 00:00:06\"],\n ];\n for(const r of rows){\n await sqlite.execute({sql:`INSERT INTO ${T}\n (id,priority,op,payload_json,state,lease_owner,lease_expires_at,created_at,updated_at)\n VALUES(?,?,?,?,?,?,?,?,?)`,args:r});\n }\n const leader:any=(await sqlite.execute(`SELECT id,state,lease_owner,op,payload_json,updated_at AS leased_at FROM ${T} WHERE id='leader'`)).rows?.[0];\n if(!mayCoalesceSuccessfulLeader(leader,true,\"w\")) throw new Error(\"SETUP_LEADER_NOT_ELIGIBLE\");\n const result=JSON.stringify({returncode:0,stdout:'{\"ok\":true}\\\\n',stderr:\"\",stdout_truncated:false,stderr_truncated:false});\n const c:any=await sqlite.execute({sql:coalesceFollowersSql(T),args:[result,leader.op,leader.payload_json,leader.leased_at]});\n const ids=(c.rows||[]).map((x:any)=>String(x.id)).sort();\n const mutationState:any=(await sqlite.execute(`SELECT state FROM ${T} WHERE id='mutation'`)).rows?.[0]?.state;\n const followerState:any=(await sqlite.execute(`SELECT state FROM ${T} WHERE id='follower'`)).rows?.[0]?.state;\n const pass=ids.length===0 && mutationState===\"READY\" && followerState===\"READY\";\n const report={\n ok:pass,\n classification:pass?\"ORDERING_BARRIER_PASS\":\"ORDERING_BARRIER_FAIL\",\n scenario:\"same-priority leader read -> mutation -> exact follower read, all queued before leader lease\",\n expected:\"follower must remain READY because FIFO would execute mutation before follower\",\n observed:{coalesced:ids,mutationState,followerState},\n defect:pass?null:\"coalescer ignores intervening mutation and can serve a pre-mutation snapshot to a read ordered after that mutation\"\n };\n console.log(JSON.stringify(report,null,2));\n if(!pass) throw new Error(\"INTERVENING_MUTATION_ORDERING_VIOLATION\");\n}finally{\n await sqlite.execute(`DROP TABLE IF EXISTS ${T}`);\n}",[150],"b9f7f3e7-f52f-4ec6-b823-a129d1e5d31e","coalesce_e72c_boundary_test.ts","01a07474-d845-763b-8ed2-4449ec6bcf0e",["D",1788660209734],"import { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\nimport { coalesceFollowersSql, mayCoalesceSuccessfulLeader } from \"./brain_bridge_readonly_coalesce_v1_candidate.ts\";\nimport { resultSql } from \"./brain_bridge_worker.ts\";\n\ntype Check={name:string;pass:boolean;detail?:unknown};\nconst checks:Check[]=[];\nconst check=(name:string,pass:boolean,detail?:unknown)=>checks.push({name,pass,detail});\nconst T=\"coalesce_boundary_\"+crypto.randomUUID().replaceAll(\"-\",\"\");\nconst p=JSON.stringify({args:[\"verify-chain\"],timeout:60});\nawait sqlite.execute(`CREATE TABLE ${T}(\n id TEXT PRIMARY KEY, priority REAL, op TEXT, payload_json TEXT, state TEXT,\n lease_owner TEXT, lease_expires_at TEXT, result_json TEXT, error_json TEXT,\n created_at TEXT, updated_at TEXT)`);\n\nasync function reset(){await sqlite.execute(`DELETE FROM ${T}`)}\nasync function seed(expiryExpr:string){\n await sqlite.execute({sql:`INSERT INTO ${T}\n (id,priority,op,payload_json,state,lease_owner,lease_expires_at,result_json,error_json,created_at,updated_at)\n VALUES('leader',0,'brain',?,'LEASED','w',datetime('now',?),NULL,NULL,datetime('now','-20 seconds'),datetime('now','-10 seconds'))`,\n args:[p,expiryExpr]});\n await sqlite.execute({sql:`INSERT INTO ${T}\n (id,priority,op,payload_json,state,lease_owner,lease_expires_at,result_json,error_json,created_at,updated_at)\n VALUES('follower',0,'brain',?,'READY',NULL,NULL,NULL,NULL,datetime('now','-15 seconds'),datetime('now','-15 seconds'))`,\n args:[p]});\n}\nasync function snapshot(){\n return (await sqlite.execute(`SELECT id,state,lease_owner,op,payload_json,updated_at AS leased_at FROM ${T} WHERE id='leader'`)).rows?.[0] as any;\n}\nasync function integrate(result:any){\n const leader=await snapshot();\n const resultText=JSON.stringify(result);\n const rr:any=await sqlite.execute({\n sql:resultSql(T),\n args:[\"COMPLETE\",resultText,null,\"leader\",\"w\"],\n });\n let coalesced:string[]=[];\n if(rr.rows?.length && mayCoalesceSuccessfulLeader(leader,true,\"w\")){\n const cr:any=await sqlite.execute({sql:coalesceFollowersSql(T),args:[resultText,leader.op,leader.payload_json,leader.leased_at]});\n coalesced=(cr.rows||[]).map((x:any)=>String(x.id));\n }\n const follower=(await sqlite.execute(`SELECT state,result_json FROM ${T} WHERE id='follower'`)).rows?.[0] as any;\n return {leaderUpdateRows:rr.rows?.length||0,coalesced,follower};\n}\n\ntry{\n await reset();\n await seed(\"-1 second\");\n const expired=await integrate({returncode:0,stdout:'{\"ok\":true}\\\\n',stderr:\"\",stdout_truncated:false,stderr_truncated:false});\n check(\"existing_resultSql_blocks_expired_lease_before_fanout\",\n expired.leaderUpdateRows===0 && expired.coalesced.length===0 && expired.follower.state===\"READY\",expired);\n\n await reset();\n await seed(\"+120 seconds\");\n const good=await integrate({returncode:0,stdout:'{\"ok\":true}\\\\n',stderr:\"\",stdout_truncated:false,stderr_truncated:false});\n check(\"natural_composition_fans_out_valid_good_result\",\n good.leaderUpdateRows===1 && good.coalesced.includes(\"follower\") && good.follower.state===\"COMPLETE\",good);\n\n await reset();\n await seed(\"+120 seconds\");\n const truncated=await integrate({returncode:0,stdout:'{\"partial\":',stderr:\"\",stdout_truncated:true,stderr_truncated:false});\n check(\"natural_composition_must_reject_truncated_result\",\n truncated.leaderUpdateRows===1 && truncated.coalesced.length===0 && truncated.follower.state===\"READY\",truncated);\n\n await reset();\n await seed(\"+120 seconds\");\n const missingEnvelope=await integrate(null);\n check(\"natural_composition_must_reject_missing_result_envelope\",\n missingEnvelope.leaderUpdateRows===1 && missingEnvelope.coalesced.length===0 && missingEnvelope.follower.state===\"READY\",missingEnvelope);\n\n const failed=checks.filter(x=>!x.pass);\n const report={ok:failed.length===0,classification:failed.length?\"COALESCE_CURRENT_RESULT_PATH_FAIL\":\"COALESCE_CURRENT_RESULT_PATH_PASS\",checks,failed};\n console.log(JSON.stringify(report,null,2));\n if(failed.length) throw new Error(\"BOUNDARY_FAILURES=\"+failed.map(x=>x.name).join(\",\"));\n}finally{\n await sqlite.execute(`DROP TABLE IF EXISTS ${T}`);\n}",[157],"a7600071-f33a-4f6b-8392-9dc816320925","coalesce_e72c_adv_test.ts","01a07474-d845-763b-8ed2-41a6d012e16c",["D",1788660209734],"import { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\nimport {\n coalesceFollowersSql,\n mayCoalesceSuccessfulLeader,\n readonlyBrainCommand,\n} from \"./brain_bridge_readonly_coalesce_v1_candidate.ts\";\n\ntype Check = {name:string; pass:boolean; detail?:unknown};\nconst checks:Check[]=[];\nfunction check(name:string, pass:boolean, detail?:unknown){ checks.push({name,pass,detail}); }\n\nconst T=\"brain_bridge_coalesce_adv_\"+crypto.randomUUID().replaceAll(\"-\",\"\");\nconst p60=JSON.stringify({args:[\"verify-chain\"],timeout:60});\nconst p30=JSON.stringify({args:[\"verify-chain\"],timeout:30});\nconst pPretty='{\"args\": [\"verify-chain\"], \"timeout\": 60}';\nconst write=JSON.stringify({args:[\"register-agent\",\"x\"],timeout:60});\n\nawait sqlite.execute(`CREATE TABLE ${T}(\n id TEXT PRIMARY KEY, priority REAL, op TEXT, payload_json TEXT, state TEXT,\n lease_owner TEXT, lease_expires_at TEXT, result_json TEXT, error_json TEXT,\n created_at TEXT, updated_at TEXT)`);\n\nasync function reset(){ await sqlite.execute(`DELETE FROM ${T}`); }\nasync function ins(id:string,op:string,payload:string,state:string,owner:string|null,expires:string|null,created:string,updated:string){\n await sqlite.execute({\n sql:`INSERT INTO ${T}(id,priority,op,payload_json,state,lease_owner,lease_expires_at,result_json,error_json,created_at,updated_at)\n VALUES(?,0,?,?,?,?,?,NULL,NULL,?,?)`,\n args:[id,op,payload,state,owner,expires,created,updated],\n });\n}\nasync function row(id:string){\n return (await sqlite.execute({sql:`SELECT * FROM ${T} WHERE id=?`,args:[id]})).rows?.[0] as any;\n}\nasync function coalesceIfEligible(leader:any,success:boolean,worker:string,result:string){\n if(!mayCoalesceSuccessfulLeader(leader,success,worker)) return [] as string[];\n const r:any=await sqlite.execute({\n sql:coalesceFollowersSql(T),\n args:[result,leader.op,leader.payload_json,leader.leased_at],\n });\n return (r.rows||[]).map((x:any)=>String(x.id)).sort();\n}\n\ntry {\n check(\"recognizes_status\", readonlyBrainCommand(\"brain\",JSON.stringify({args:[\"status\"],timeout:60}))===\"status\");\n check(\"recognizes_verify_chain\", readonlyBrainCommand(\"brain\",p60)===\"verify-chain\");\n check(\"recognizes_verify_claim_graph\", readonlyBrainCommand(\"brain\",JSON.stringify({args:[\"verify-claim-graph\"],timeout:60}))===\"verify-claim-graph\");\n check(\"rejects_mutating_command\", readonlyBrainCommand(\"brain\",write)===null);\n check(\"rejects_read_text\", readonlyBrainCommand(\"read_text\",JSON.stringify({path:\"/brain/JOIN_PROTOCOL.md\",max_bytes:1}))===null);\n check(\"rejects_open_schema\", readonlyBrainCommand(\"brain\",JSON.stringify({args:[\"status\"],timeout:60,extra:true}))===null);\n check(\"rejects_multi_arg_read\", readonlyBrainCommand(\"brain\",JSON.stringify({args:[\"status\",\"extra\"],timeout:60}))===null);\n\n await reset();\n await ins(\"leader\",\"brain\",p60,\"LEASED\",\"w\",\"2026-01-01 00:03:10\",\"2026-01-01 00:00:01\",\"2026-01-01 00:00:10\");\n await ins(\"before\",\"brain\",p60,\"READY\",null,null,\"2026-01-01 00:00:02\",\"2026-01-01 00:00:02\");\n await ins(\"same-second\",\"brain\",p60,\"READY\",null,null,\"2026-01-01 00:00:10\",\"2026-01-01 00:00:10\");\n await ins(\"later\",\"brain\",p60,\"READY\",null,null,\"2026-01-01 00:00:11\",\"2026-01-01 00:00:11\");\n await ins(\"timeout-mismatch\",\"brain\",p30,\"READY\",null,null,\"2026-01-01 00:00:02\",\"2026-01-01 00:00:02\");\n await ins(\"payload-byte-mismatch\",\"brain\",pPretty,\"READY\",null,null,\"2026-01-01 00:00:02\",\"2026-01-01 00:00:02\");\n const leader:any={...(await row(\"leader\")),leased_at:\"2026-01-01 00:00:10\"};\n const good=JSON.stringify({returncode:0,stdout:'{\"ok\":true}\\\\n',stderr:\"\",stdout_truncated:false,stderr_truncated:false});\n const ids=await coalesceIfEligible(leader,true,\"w\",good);\n check(\"leader_success_coalesces_exact_prelease\", JSON.stringify(ids)===JSON.stringify([\"before\"]), ids);\n check(\"same_second_arrival_not_coalesced\",(await row(\"same-second\")).state===\"READY\");\n check(\"later_arrival_not_coalesced\",(await row(\"later\")).state===\"READY\");\n check(\"timeout_mismatch_not_coalesced\",(await row(\"timeout-mismatch\")).state===\"READY\");\n check(\"payload_byte_mismatch_not_coalesced\",(await row(\"payload-byte-mismatch\")).state===\"READY\");\n\n await reset();\n await ins(\"leader\",\"brain\",p60,\"LEASED\",\"w\",\"2026-01-01 00:03:10\",\"2026-01-01 00:00:01\",\"2026-01-01 00:00:10\");\n await ins(\"follower\",\"brain\",p60,\"READY\",null,null,\"2026-01-01 00:00:02\",\"2026-01-01 00:00:02\");\n const failLeader:any={...(await row(\"leader\")),leased_at:\"2026-01-01 00:00:10\"};\n const failIds=await coalesceIfEligible(failLeader,false,\"w\",good);\n check(\"leader_failure_not_coalesced\",failIds.length===0 && (await row(\"follower\")).state===\"READY\",failIds);\n\n await reset();\n await ins(\"leader\",\"brain\",p60,\"LEASED\",\"w\",\"2026-01-01 00:03:10\",\"2026-01-01 00:00:01\",\"2026-01-01 00:00:10\");\n await ins(\"post\",\"brain\",p60,\"READY\",null,null,\"2026-01-01 00:00:20\",\"2026-01-01 00:00:20\");\n const staleLeader:any={...(await row(\"leader\")),leased_at:\"2026-01-01 00:00:10\"};\n await coalesceIfEligible(staleLeader,true,\"w\",good);\n check(\"post_lease_arrival_not_served_stale_result\",(await row(\"post\")).state===\"READY\");\n\n await reset();\n await ins(\"leader\",\"brain\",p60,\"LEASED\",\"w\",\"2026-01-01 00:03:10\",\"2026-01-01 00:00:01\",\"2026-01-01 00:00:10\");\n await ins(\"race-follower\",\"brain\",p60,\"READY\",null,null,\"2026-01-01 00:00:02\",\"2026-01-01 00:00:02\");\n const raceLeader:any={...(await row(\"leader\")),leased_at:\"2026-01-01 00:00:10\"};\n const [r1,r2]=await Promise.all([\n coalesceIfEligible(raceLeader,true,\"w\",good),\n coalesceIfEligible(raceLeader,true,\"w\",good),\n ]);\n const raceHits=[...r1,...r2].filter(x=>x===\"race-follower\").length;\n check(\"concurrent_updates_claim_follower_once\",raceHits===1,{r1,r2,raceHits});\n\n const expired:any={\n id:\"expired\",state:\"LEASED\",lease_owner:\"w\",op:\"brain\",payload_json:p60,\n leased_at:\"2026-01-01 00:00:10\",lease_expires_at:\"2026-01-01 00:03:10\"\n };\n check(\"expired_leader_rejected\", mayCoalesceSuccessfulLeader(expired,true,\"w\")===false, {\n observed:mayCoalesceSuccessfulLeader(expired,true,\"w\"),\n lease_expires_at:expired.lease_expires_at,\n note:\"candidate guard has no expiry input/check\"\n });\n\n await reset();\n await ins(\"leader\",\"brain\",p60,\"LEASED\",\"w\",\"2026-01-01 00:03:10\",\"2026-01-01 00:00:01\",\"2026-01-01 00:00:10\");\n await ins(\"follower\",\"brain\",p60,\"READY\",null,null,\"2026-01-01 00:00:02\",\"2026-01-01 00:00:02\");\n const truncLeader:any={...(await row(\"leader\")),leased_at:\"2026-01-01 00:00:10\"};\n const truncated=JSON.stringify({\n returncode:0,stdout:\"{\\\\\\\"partial\\\\\\\":\",stderr:\"\",\n stdout_truncated:true,stderr_truncated:false\n });\n const truncIds=await coalesceIfEligible(truncLeader,true,\"w\",truncated);\n const truncFollower=await row(\"follower\");\n check(\"truncated_success_not_fanned_out\",\n truncIds.length===0 && truncFollower.state===\"READY\",\n {truncIds,follower_state:truncFollower.state,result_json:truncFollower.result_json}\n );\n\n const failed=checks.filter(x=>!x.pass);\n const report={\n ok:failed.length===0,\n classification:failed.length===0?\"READONLY_COALESCE_ADVERSARIAL_PASS\":\"READONLY_COALESCE_ADVERSARIAL_FAIL\",\n checks:checks.length,\n passed:checks.length-failed.length,\n failed:failed.length,\n failures:failed,\n results:checks,\n };\n console.log(JSON.stringify(report,null,2));\n if(failed.length) throw new Error(\"ADVERSARIAL_FAILURES=\"+failed.map(x=>x.name).join(\",\"));\n} finally {\n await sqlite.execute(`DROP TABLE IF EXISTS ${T}`);\n}\n",[163],"6b3f6f59-2014-44d7-9197-a5d190c4cb69","brain_bridge_worker.ts",4,["D",1788660211007],"http","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 \"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='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\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 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 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:\"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 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",[169],"057a38f0-13e9-4f95-a1c5-f5f2582c55c6","brain_bridge_readonly_coalesce_v2_test.ts","b3bea810-a997-11f1-8dc3-1607ee4eb77e",9,["D",1788660444559],"import { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\nimport { coalesceFollowersSql, mayCoalesceSuccessfulLeader, readonlyBrainCommand } from \"./brain_bridge_readonly_coalesce_v2_candidate.ts\";\n\nfunction assert(c:boolean,m:string){ if(!c) throw new Error(m); }\nconst T=\"brain_bridge_coalesce_v2_source_\"+crypto.randomUUID().replaceAll(\"-\",\"\");\nconst p=JSON.stringify({args:[\"verify-chain\"],timeout:60});\nconst pOtherTimeout=JSON.stringify({args:[\"verify-chain\"],timeout:30});\nconst write=JSON.stringify({args:[\"register-agent\",\"x\"],timeout:60});\nawait sqlite.execute(`CREATE TABLE ${T}(\n id TEXT PRIMARY KEY, priority REAL NOT NULL DEFAULT 0, op TEXT, payload_json TEXT, state TEXT,\n lease_owner TEXT, lease_expires_at TEXT, result_json TEXT, error_json TEXT,\n created_at TEXT, updated_at TEXT)`);\ntry{\n const rows=[\n [\"leader\",0,\"brain\",p,\"LEASED\",\"w\",\"2099-01-01 00:03:10\",\"2026-01-01 00:00:01\",\"2026-01-01 00:00:10\"],\n [\"before-a\",0,\"brain\",p,\"READY\",null,null,\"2026-01-01 00:00:02\",\"2026-01-01 00:00:02\"],\n [\"before-b\",0,\"brain\",p,\"READY\",null,null,\"2026-01-01 00:00:09\",\"2026-01-01 00:00:09\"],\n [\"same-second\",0,\"brain\",p,\"READY\",null,null,\"2026-01-01 00:00:10\",\"2026-01-01 00:00:10\"],\n [\"during\",0,\"brain\",p,\"READY\",null,null,\"2026-01-01 00:00:11\",\"2026-01-01 00:00:11\"],\n [\"different-timeout\",0,\"brain\",pOtherTimeout,\"READY\",null,null,\"2026-01-01 00:00:02\",\"2026-01-01 00:00:02\"],\n [\"write\",-1,\"brain\",write,\"READY\",null,null,\"2026-01-01 00:00:02\",\"2026-01-01 00:00:02\"]\n ];\n for(const r of rows){\n await sqlite.execute({sql:`INSERT INTO ${T}\n (id,priority,op,payload_json,state,lease_owner,lease_expires_at,created_at,updated_at)\n VALUES(?,?,?,?,?,?,?,?,?)`,args:r});\n }\n assert(readonlyBrainCommand(\"brain\",p)===\"verify-chain\",\"read-only recognition\");\n assert(readonlyBrainCommand(\"brain\",pOtherTimeout)===\"verify-chain\",\"timeout variant still read-only\");\n assert(readonlyBrainCommand(\"brain\",write)===null,\"mutating command rejected\");\n assert(readonlyBrainCommand(\"read_text\",JSON.stringify({path:\"/brain/JOIN_PROTOCOL.md\",max_bytes:1}))===null,\"read_text not coalesced\");\n assert(readonlyBrainCommand(\"brain\",JSON.stringify({args:[\"status\"],timeout:60,extra:true}))===null,\"open schema rejected\");\n\n const leader:any=(await sqlite.execute(`SELECT id,state,lease_owner,lease_expires_at,op,payload_json,updated_at AS leased_at FROM ${T} WHERE id='leader'`)).rows[0];\n assert(mayCoalesceSuccessfulLeader(leader,true,\"w\"),\"successful leased leader accepted\");\n assert(!mayCoalesceSuccessfulLeader(leader,false,\"w\"),\"failure never coalesces\");\n assert(!mayCoalesceSuccessfulLeader(leader,true,\"other\"),\"wrong worker rejected\");\n\n const result=JSON.stringify({returncode:0,stdout:'{\"ok\":true}\\\\n',stderr:\"\",stdout_truncated:false,stderr_truncated:false});\n const c:any=await sqlite.execute({sql:coalesceFollowersSql(T),args:[result,leader.op,leader.payload_json,leader.leased_at]});\n const ids=(c.rows||[]).map((x:any)=>x.id).sort();\n assert(JSON.stringify(ids)===JSON.stringify([\"before-a\",\"before-b\"]),\"only pre-lease exact duplicates coalesced: \"+JSON.stringify(ids));\n\n const state:any=await sqlite.execute(`SELECT id,state,result_json,lease_owner FROM ${T} ORDER BY id`);\n const by=Object.fromEntries(state.rows.map((x:any)=>[x.id,x]));\n assert(by[\"before-a\"].state===\"COMPLETE\" && by[\"before-a\"].result_json===result,\"result copied byte-exactly\");\n assert(by[\"before-a\"].lease_owner===null,\"follower not falsely represented as leased\");\n assert(by[\"same-second\"].state===\"READY\",\"same-second boundary fails conservative\");\n assert(by[\"during\"].state===\"READY\",\"post-lease arrival remains fresh\");\n assert(by[\"different-timeout\"].state===\"READY\",\"different payload remains\");\n assert(by[\"write\"].state===\"READY\",\"lower-priority write remains\");\n console.log(JSON.stringify({ok:true,classification:\"READONLY_V2_SOURCE_PARITY_PASS\",assertions:14,coalesced:ids},null,2));\n} finally {\n await sqlite.execute(`DROP TABLE IF EXISTS ${T}`);\n}",[176],"13b3d660-4fc5-4f40-aa27-314286f9dbb0","brain_bridge_readonly_coalesce_v2_candidate.ts","d2e5ef0a-a997-11f1-9fbd-1607ee4eb77e",11,["D",1788660496849],"export const READ_ONLY_BRAIN_COMMANDS = new Set([\"status\",\"verify-chain\",\"verify-claim-graph\"]);\nexport const PRIORITY_CAP = 1_000_000_000;\n\nexport function readonlyBrainCommand(op:string,payloadJson:string):string|null {\n if(op!==\"brain\") return null;\n let q:any;\n try { q=JSON.parse(payloadJson); } catch { return null; }\n if(!q || typeof q!==\"object\" || Array.isArray(q)) return null;\n const keys=Object.keys(q).sort();\n if(keys.length!==2 || keys[0]!==\"args\" || keys[1]!==\"timeout\") return null;\n if(!Array.isArray(q.args) || q.args.length!==1 || typeof q.args[0]!==\"string\") return null;\n if(!Number.isInteger(q.timeout) || q.timeout<1 || q.timeout>120) return null;\n return READ_ONLY_BRAIN_COMMANDS.has(q.args[0]) ? q.args[0] : null;\n}\n\nexport function validReadonlyResultEnvelope(resultJson:string|null|undefined):boolean {\n if(typeof resultJson!==\"string\") return false;\n let q:any;\n try { q=JSON.parse(resultJson); } catch { return false; }\n if(!q || typeof q!==\"object\" || Array.isArray(q)) return false;\n const keys=Object.keys(q).sort();\n const expected=[\"returncode\",\"stderr\",\"stderr_truncated\",\"stdout\",\"stdout_truncated\"];\n if(keys.length!==expected.length || !keys.every((k,i)=>k===expected[i])) return false;\n return Number.isInteger(q.returncode)\n && q.returncode===0\n && typeof q.stdout===\"string\"\n && typeof q.stderr===\"string\"\n && q.stdout_truncated===false\n && q.stderr_truncated===false;\n}\n\nfunction tableName(table:string){\n if(!/^[A-Za-z_][A-Za-z0-9_]*$/.test(table)) throw new Error(\"BAD_TABLE\");\n return table;\n}\n\nfunction closedResultEnvelopeSql(expr:string){\n return `CASE WHEN json_valid(${expr})=1 THEN\n CASE WHEN json_type(${expr},'$')='object' THEN\n CASE WHEN (SELECT COUNT(*) FROM json_each(${expr}))=5\n AND json_type(${expr},'$.returncode')='integer'\n AND json_extract(${expr},'$.returncode')=0\n AND json_type(${expr},'$.stdout')='text'\n AND json_type(${expr},'$.stderr')='text'\n AND json_type(${expr},'$.stdout_truncated')='false'\n AND json_type(${expr},'$.stderr_truncated')='false'\n THEN 1 ELSE 0 END\n ELSE 0 END\n ELSE 0 END`;\n}\n\nfunction closedReadonlyBrainSql(alias:string){\n const p=`${alias}.payload_json`;\n return `CASE WHEN ${alias}.op='brain' AND json_valid(${p})=1 THEN\n CASE WHEN json_type(${p},'$')='object'\n AND (SELECT COUNT(*) FROM json_each(${p}))=2\n AND json_type(${p},'$.args')='array'\n AND json_array_length(json_extract(${p},'$.args'))=1\n AND json_type(${p},'$.args[0]')='text'\n AND json_extract(${p},'$.args[0]') IN ('status','verify-chain','verify-claim-graph')\n AND json_type(${p},'$.timeout')='integer'\n AND json_extract(${p},'$.timeout') BETWEEN 1 AND 120\n THEN 1 ELSE 0 END\n ELSE 0 END`;\n}\n\nfunction exactRecoverStaleSql(alias:string){\n const p=`${alias}.payload_json`;\n return `CASE WHEN ${alias}.op='brain' AND json_valid(${p})=1 THEN\n CASE WHEN json_type(${p},'$')='object'\n AND (SELECT COUNT(*) FROM json_each(${p}))=2\n AND json_type(${p},'$.args')='array'\n AND json_array_length(json_extract(${p},'$.args'))=1\n AND json_extract(${p},'$.args[0]')='recover-stale'\n AND json_type(${p},'$.timeout')='integer'\n AND json_extract(${p},'$.timeout') BETWEEN 1 AND 120\n THEN 1 ELSE 0 END\n ELSE 0 END`;\n}\n\nfunction effectivePrioritySql(alias:string){\n return `CASE WHEN ${alias}.priority > ${PRIORITY_CAP} THEN ${PRIORITY_CAP} ELSE ${alias}.priority END`;\n}\n\nexport function coalesceFollowersSql(table=\"brain_bridge_jobs\"){\n table=tableName(table);\n const resultOk=closedResultEnvelopeSql(\"?1\");\n const barrierReadonly=closedReadonlyBrainSql(\"b\");\n const barrierRecover=exactRecoverStaleSql(\"b\");\n const bPriority=effectivePrioritySql(\"b\");\n const fPriority=effectivePrioritySql(\"f\");\n return `UPDATE ${table} AS f\n SET state='COMPLETE',\n result_json=?1,\n error_json=NULL,\n lease_owner=NULL,\n lease_expires_at=NULL,\n updated_at=datetime('now')\n WHERE f.state='READY'\n AND f.op=?2\n AND f.payload_json=?3\n AND f.created_at < ?4\n AND (${resultOk})=1\n AND NOT EXISTS (\n SELECT 1 FROM ${table} AS b\n WHERE b.state='READY'\n AND b.op='brain'\n AND (${barrierReadonly})=0\n AND (\n (${barrierRecover})=1\n OR (\n (${barrierRecover})=0\n AND (\n ${bPriority} > ${fPriority}\n OR (\n ${bPriority} = ${fPriority}\n AND (\n b.created_at < f.created_at\n OR (b.created_at=f.created_at AND b.id < f.id)\n )\n )\n )\n )\n )\n )\n RETURNING id`;\n}\n\nexport type LeaderSnapshot={\n id:string;\n state:string;\n lease_owner:string|null;\n op:string;\n payload_json:string;\n leased_at:string;\n lease_expires_at?:string|null;\n};\n\nfunction parseSqliteUtc(s:string):number {\n const t=Date.parse(s.includes(\"T\") ? s : s.replace(\" \",\"T\")+\"Z\");\n return t;\n}\n\nexport function mayCoalesceSuccessfulLeader(\n leader:LeaderSnapshot,\n success:boolean,\n worker:string,\n):boolean {\n if(success!==true\n || leader.state!==\"LEASED\"\n || leader.lease_owner!==worker\n || readonlyBrainCommand(leader.op,leader.payload_json)===null) return false;\n if(Object.prototype.hasOwnProperty.call(leader,\"lease_expires_at\") && leader.lease_expires_at!==null){\n if(typeof leader.lease_expires_at!==\"string\") return false;\n const expiry=parseSqliteUtc(leader.lease_expires_at);\n if(!Number.isFinite(expiry) || expiry<=Date.now()) return false;\n }\n return true;\n}\n",[183],"51b92974-5757-4047-9f8a-6a6bb801f3b2","brain_bridge_readonly_coalesce_v1_test.ts","01a07474-d2f9-700b-b98b-525025b02d85",2,["D",1788660208378],"import { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\nimport { coalesceFollowersSql, mayCoalesceSuccessfulLeader, readonlyBrainCommand } from \"./brain_bridge_readonly_coalesce_v1_candidate.ts\";\n\nfunction assert(c:boolean,m:string){ if(!c) throw new Error(m); }\nconst T=\"brain_bridge_coalesce_test_\"+crypto.randomUUID().replaceAll(\"-\",\"\");\nconst p=JSON.stringify({args:[\"verify-chain\"],timeout:60});\nconst pOtherTimeout=JSON.stringify({args:[\"verify-chain\"],timeout:30});\nconst write=JSON.stringify({args:[\"register-agent\",\"x\"],timeout:60});\nawait sqlite.execute(`CREATE TABLE ${T}(\n id TEXT PRIMARY KEY, priority REAL, op TEXT, payload_json TEXT, state TEXT,\n lease_owner TEXT, lease_expires_at TEXT, result_json TEXT, error_json TEXT,\n created_at TEXT, updated_at TEXT)`);\ntry{\n const rows=[\n [\"leader\",\"brain\",p,\"LEASED\",\"w\",\"2026-01-01 00:03:10\",\"2026-01-01 00:00:01\",\"2026-01-01 00:00:10\"],\n [\"before-a\",\"brain\",p,\"READY\",null,null,\"2026-01-01 00:00:02\",\"2026-01-01 00:00:02\"],\n [\"before-b\",\"brain\",p,\"READY\",null,null,\"2026-01-01 00:00:09\",\"2026-01-01 00:00:09\"],\n [\"same-second\",\"brain\",p,\"READY\",null,null,\"2026-01-01 00:00:10\",\"2026-01-01 00:00:10\"],\n [\"during\",\"brain\",p,\"READY\",null,null,\"2026-01-01 00:00:11\",\"2026-01-01 00:00:11\"],\n [\"different-timeout\",\"brain\",pOtherTimeout,\"READY\",null,null,\"2026-01-01 00:00:02\",\"2026-01-01 00:00:02\"],\n [\"write\",\"brain\",write,\"READY\",null,null,\"2026-01-01 00:00:02\",\"2026-01-01 00:00:02\"]\n ];\n for(const r of rows){\n await sqlite.execute({sql:`INSERT INTO ${T}\n (id,priority,op,payload_json,state,lease_owner,lease_expires_at,created_at,updated_at)\n VALUES(?,0,?,?,?,?,?,?,?)`,args:r});\n }\n assert(readonlyBrainCommand(\"brain\",p)===\"verify-chain\",\"read-only recognition\");\n assert(readonlyBrainCommand(\"brain\",pOtherTimeout)===\"verify-chain\",\"timeout variant still read-only\");\n assert(readonlyBrainCommand(\"brain\",write)===null,\"mutating command rejected\");\n assert(readonlyBrainCommand(\"read_text\",JSON.stringify({path:\"/brain/JOIN_PROTOCOL.md\",max_bytes:1}))===null,\"read_text not coalesced\");\n assert(readonlyBrainCommand(\"brain\",JSON.stringify({args:[\"status\"],timeout:60,extra:true}))===null,\"open schema rejected\");\n\n const leader:any=(await sqlite.execute(`SELECT id,state,lease_owner,op,payload_json,updated_at AS leased_at FROM ${T} WHERE id='leader'`)).rows[0];\n assert(mayCoalesceSuccessfulLeader(leader,true,\"w\"),\"successful leased leader accepted\");\n assert(!mayCoalesceSuccessfulLeader(leader,false,\"w\"),\"failure never coalesces\");\n assert(!mayCoalesceSuccessfulLeader(leader,true,\"other\"),\"wrong worker rejected\");\n\n const result=JSON.stringify({returncode:0,stdout:'{\"ok\":true}\\\\n',stderr:\"\"});\n const c:any=await sqlite.execute({sql:coalesceFollowersSql(T),args:[result,leader.op,leader.payload_json,leader.leased_at]});\n const ids=(c.rows||[]).map((x:any)=>x.id).sort();\n assert(JSON.stringify(ids)===JSON.stringify([\"before-a\",\"before-b\"]),\"only pre-lease exact duplicates coalesced: \"+JSON.stringify(ids));\n\n const state:any=await sqlite.execute(`SELECT id,state,result_json,lease_owner FROM ${T} ORDER BY id`);\n const by=Object.fromEntries(state.rows.map((x:any)=>[x.id,x]));\n assert(by[\"before-a\"].state===\"COMPLETE\" && by[\"before-a\"].result_json===result,\"result copied byte-exactly\");\n assert(by[\"before-a\"].lease_owner===null,\"follower not falsely represented as leased\");\n assert(by[\"same-second\"].state===\"READY\",\"same-second boundary fails conservative\");\n assert(by[\"during\"].state===\"READY\",\"post-lease arrival remains fresh\");\n assert(by[\"different-timeout\"].state===\"READY\",\"different payload remains\");\n assert(by[\"write\"].state===\"READY\",\"write remains\");\n console.log(JSON.stringify({ok:true,classification:\"READONLY_PRELEASE_EXACT_COALESCE_PASS\",assertions:14,coalesced:ids},null,2));\n} finally {\n await sqlite.execute(`DROP TABLE IF EXISTS ${T}`);\n}",[190],"29fe64ce-f4f0-4438-929e-4b583ef83b5c","brain_bridge_readonly_coalesce_v1_candidate.ts","01a07474-d2f9-700b-b98b-4e6cccc78209",["D",1788660208378],"export const READ_ONLY_BRAIN_COMMANDS = new Set([\"status\",\"verify-chain\",\"verify-claim-graph\"]);\n\nexport function readonlyBrainCommand(op:string,payloadJson:string):string|null {\n if(op!==\"brain\") return null;\n let q:any;\n try { q=JSON.parse(payloadJson); } catch { return null; }\n if(!q || typeof q!==\"object\" || Array.isArray(q)) return null;\n const keys=Object.keys(q).sort();\n if(keys.length!==2 || keys[0]!==\"args\" || keys[1]!==\"timeout\") return null;\n if(!Array.isArray(q.args) || q.args.length!==1 || typeof q.args[0]!==\"string\") return null;\n if(!Number.isInteger(q.timeout) || q.timeout<1 || q.timeout>120) return null;\n return READ_ONLY_BRAIN_COMMANDS.has(q.args[0]) ? q.args[0] : null;\n}\n\nfunction tableName(table:string){\n if(!/^[A-Za-z_][A-Za-z0-9_]*$/.test(table)) throw new Error(\"BAD_TABLE\");\n return table;\n}\n\nexport function coalesceFollowersSql(table=\"brain_bridge_jobs\"){\n table=tableName(table);\n return `UPDATE ${table}\n SET state='COMPLETE',\n result_json=?,\n error_json=NULL,\n lease_owner=NULL,\n lease_expires_at=NULL,\n updated_at=datetime('now')\n WHERE state='READY'\n AND op=?\n AND payload_json=?\n AND created_at < ?\n RETURNING id`;\n}\n\nexport type LeaderSnapshot={\n id:string;\n state:string;\n lease_owner:string|null;\n op:string;\n payload_json:string;\n leased_at:string;\n};\n\nexport function mayCoalesceSuccessfulLeader(\n leader:LeaderSnapshot,\n success:boolean,\n worker:string,\n):boolean {\n return success===true\n && leader.state===\"LEASED\"\n && leader.lease_owner===worker\n && readonlyBrainCommand(leader.op,leader.payload_json)!==null;\n}\n",[197],"6f75015b-5ec1-4e22-bc81-5914eda752a3","README.md","22efdef8-a997-11f1-b55c-1607ee4eb77e",["D",1788660201636],"# Brain Coalescer V2 A19C\n\nIsolated nonauthority repair workspace.\n",[203],"226ee7b5-14d7-43f9-a99f-6033beb98aba","docs","6659917a-a997-11f1-9514-1607ee4eb77e",5,["D",1788660314741],"directory",[209],"pulls","branches","forks","envVars",{"_222":63,"_224":63},"connections",{"_222":63,"_223":63},"count","unfilledCount","emptyCount",{"_43":208,"_32":209,"_30":210,"_143":-5,"_41":42,"_40":211,"_144":59,"_38":292,"_13":63,"_33":213,"_35":-5,"_24":25,"_147":-5,"_240":293,"_27":294},{"_43":287,"_32":279,"_30":282,"_143":210,"_41":42,"_40":288,"_144":59,"_38":289,"_13":63,"_33":213,"_35":-5,"_24":25,"_147":-5,"_240":290,"_27":291},{"_43":281,"_32":280,"_30":273,"_143":282,"_41":42,"_40":283,"_144":59,"_38":284,"_13":63,"_33":213,"_35":-5,"_24":25,"_147":-5,"_240":285,"_27":286},{"_43":270,"_32":271,"_30":272,"_143":273,"_41":42,"_40":274,"_144":59,"_38":275,"_13":63,"_33":20,"_35":276,"_24":25,"_147":-5,"_240":277,"_27":278},{"_43":202,"_32":203,"_30":204,"_143":-5,"_41":42,"_40":146,"_144":59,"_38":267,"_13":63,"_33":20,"_35":206,"_24":25,"_147":-5,"_240":268,"_27":269},{"_43":196,"_32":197,"_30":198,"_143":-5,"_41":42,"_40":192,"_144":59,"_38":264,"_13":63,"_33":34,"_35":200,"_24":25,"_147":-5,"_240":265,"_27":266},{"_43":189,"_32":190,"_30":191,"_143":-5,"_41":42,"_40":192,"_144":59,"_38":261,"_13":63,"_33":34,"_35":194,"_24":25,"_147":-5,"_240":262,"_27":263},{"_43":182,"_32":183,"_30":184,"_143":-5,"_41":42,"_40":185,"_144":59,"_38":258,"_13":63,"_33":34,"_35":187,"_24":25,"_147":-5,"_240":259,"_27":260},{"_43":175,"_32":176,"_30":177,"_143":-5,"_41":42,"_40":178,"_144":59,"_38":255,"_13":63,"_33":34,"_35":180,"_24":25,"_147":-5,"_240":256,"_27":257},{"_43":168,"_32":169,"_30":57,"_143":-5,"_41":42,"_40":170,"_144":59,"_38":252,"_13":63,"_33":172,"_35":173,"_24":25,"_147":-5,"_240":253,"_27":254},{"_43":162,"_32":163,"_30":164,"_143":-5,"_41":42,"_40":152,"_144":25,"_38":249,"_13":63,"_33":34,"_35":166,"_24":25,"_147":-5,"_240":250,"_27":251},{"_43":156,"_32":157,"_30":158,"_143":-5,"_41":42,"_40":152,"_144":25,"_38":246,"_13":63,"_33":34,"_35":160,"_24":25,"_147":-5,"_240":247,"_27":248},{"_43":149,"_32":150,"_30":151,"_143":-5,"_41":42,"_40":152,"_144":25,"_38":243,"_13":63,"_33":34,"_35":154,"_24":25,"_147":-5,"_240":244,"_27":245},{"_43":142,"_32":28,"_30":31,"_143":-5,"_41":42,"_40":14,"_144":59,"_38":239,"_13":146,"_33":34,"_35":37,"_24":25,"_147":-5,"_240":241,"_27":242},["D",1788660555259],"children",[],[28],["D",1788660209734],[],[150],["D",1788660209734],[],[157],["D",1788660209734],[],[163],["D",1788660211007],[],[169],["D",1788660444559],[],[176],["D",1788660496849],[],[183],["D",1788660208378],[],[190],["D",1788660208378],[],[197],["D",1788660201636],[],[203],"d6692aed-3dc5-4416-bfbe-a7958af7fb7f","2026-09-06-readonly-boot-coalesce-v2.md","68c69534-a997-11f1-acf8-1607ee4eb77e","67faf794-a997-11f1-9f9a-1607ee4eb77e",8,["D",1788660318805],"# Read-Only Boot Coalescer V2 Implementation Plan\n\n> **For agentic workers:** REQUIRED SUB-SKILL: Use superpowers:executing-plans to implement this plan task-by-task.\n\n**Goal:** Repair V1 so duplicate boot reads can fan out only when the leader result is current, complete, non-truncated, schema-valid, and no scheduler-visible Brain mutation would execute before the follower.\n\n**Architecture:** Keep the V1 closed read-only command grammar and conservative pre-lease duplicate boundary. Add defense-in-depth result-envelope validation directly inside the follower UPDATE, and a correlated scheduler-order barrier that blocks any follower whose next execution would be preceded by a non-read-only Brain job. Preserve the existing resultSql-first integration path as the lease/expiry authority; add only bounded helper logic needed by the independent expiry test.\n\n**Tech Stack:** TypeScript, Val Town std/sqlite, SQLite JSON1.\n\n**Spec:** valblob:mosadek/project-brain-live-v1-durable/diagnostics/brain_bridge/readonly_coalesce/e72c_second_party_v2.json\n\n## Global Constraints\n- Candidate/nonauthority only; production project main and canonical brain.py remain untouched.\n- No direct Sprites.\n- No human_authority_approval.\n- Exact payload/timeout matching remains byte-conservative.\n- Only status, verify-chain, verify-claim-graph are coalescible.\n- Fanout is valid only after successful current resultSql lease/expiry validation.\n- No result fanout for null, malformed, open-schema, nonzero-returncode, or truncated envelopes.\n- Never move a follower read ahead of a scheduler-visible Brain mutation that would execute before it.\n- Preserve priority cap 1_000_000_000 and recover-stale recovery-first ordering semantics.\n\n---\n\n### Task 1: Reproduce V1 falsifiers in the isolated sandbox\n\n**Files:**\n- Existing: `brain_bridge_readonly_coalesce_v1_candidate.ts`\n- Existing: `brain_bridge_readonly_coalesce_v1_test.ts`\n- Existing: `coalesce_e72c_adv_test.ts`\n- Existing: `coalesce_e72c_boundary_test.ts`\n- Existing: `coalesce_e72c_order_test.ts`\n\n**Interfaces:**\n- Consumes: reviewed V1 candidate and independent tests.\n- Produces: fresh RED evidence for expiry, truncated/null result, and mutation ordering defects.\n\n- [ ] Run original 14-assertion source suite and confirm PASS.\n- [ ] Run independent adversarial suite and confirm the reviewed failures.\n- [ ] Run boundary suite and confirm truncated/null failures.\n- [ ] Run ordering suite and confirm intervening mutation violation.\n\n### Task 2: Add V2 failing regressions before implementation\n\n**Files:**\n- Create: `brain_bridge_readonly_coalesce_v2_test.ts`\n- Create: `coalesce_v2_regression_test.ts`\n\n**Interfaces:**\n- Consumes: wished-for V2 exports matching V1 names.\n- Produces: RED tests for closed result envelopes, priority/recover-stale ordering, stale replay, and read-only non-barriers.\n\n- [ ] Copy the 14 logical source assertions to V2, using a complete valid result envelope.\n- [ ] Add failing tests for extra/missing result keys, nonzero returncode, both truncation flags, and null/malformed envelopes.\n- [ ] Add failing tests for same-priority mutation, higher-priority later mutation, recover-stale rank-0 mutation, same-timestamp ID ordering, and lower-priority mutation that should not block.\n- [ ] Add stale resultSql replay test proving a second result update cannot fan out.\n- [ ] Run V2 tests and verify RED because the V2 module is absent.\n\n### Task 3: Implement the minimal V2 repair\n\n**Files:**\n- Create: `brain_bridge_readonly_coalesce_v2_candidate.ts`\n\n**Interfaces:**\n- Produces: `readonlyBrainCommand`, `coalesceFollowersSql`, `mayCoalesceSuccessfulLeader`, and result-envelope validation helpers.\n\n- [ ] Port V1 read-only recognition unchanged.\n- [ ] Add exact closed result-envelope validator.\n- [ ] Make follower UPDATE validate ?1 result bytes before changing any follower.\n- [ ] Add correlated NOT EXISTS mutation barrier using recovery-first + capped-priority + created_at,id scheduler ordering.\n- [ ] Add optional lease-expiry rejection when lease_expires_at is present.\n- [ ] Run V2 source/regression tests until GREEN.\n\n### Task 4: Re-run independent suites against V2\n\n**Files:**\n- Create V2-import copies of the three e72c suites; preserve scenarios/assertions.\n\n- [ ] Run adversarial suite; require all checks PASS.\n- [ ] Run boundary suite; require all checks PASS.\n- [ ] Run ordering suite; require PASS.\n- [ ] Re-run original V1 14/14 as baseline and V2 14/14 parity.\n\n### Task 5: Preserve and commit evidence\n\n**Files:**\n- Preserve exact candidate and test bytes/hashes in project-scoped Val Town blobs.\n- Preserve one JSON receipt with commands/results/hashes/classification.\n\n- [ ] Compute SHA-256 for candidate/tests.\n- [ ] Store candidate/tests and receipt under evidence/readonly_coalesce_v2/a19c/.\n- [ ] Verify blob readback hashes.\n- [ ] Reconcile current Brain generation.\n- [ ] Commit task result through Brain with evidence URIs/hashes.\n- [ ] Claim next causally ready task.\n",[],[209,279,280,271],"superpowers","plans","528bdad7-6718-4733-80c1-7c6541423603","6738851a-a997-11f1-a117-1607ee4eb77e",7,["D",1788660317436],[228],[209,279,280],"280ec4e5-d943-4e88-b11c-f2a553b35ad2",6,["D",1788660316198],[227],[209,279],["D",1788660314741],[226],[209],["D",1788660201596],["D",1789533091345],{"_100":99,"_108":104},{"_100":99,"_101":102,"_103":104,"_18":55,"_105":106,"_107":25},{"_13":89,"_32":90,"_43":42,"_91":44,"_92":-5,"_93":-5,"_94":-5,"_95":-5,"_96":-5,"_97":45,"_98":99},"ctx",{"_82":-5,"_128":333,"_334":335,"_336":337,"_338":25,"_339":25,"_340":25,"_341":59,"_342":-5,"_343":-7,"_344":-7,"_345":63,"_346":25,"_347":25,"_348":-5,"_349":25,"_350":25,"_351":25,"_352":-5},"ENV",{"_304":305,"_306":307,"_308":90,"_309":310,"_311":312,"_313":314,"_315":316,"_317":318,"_319":320,"_321":322,"_323":324,"_325":326,"_327":328,"_329":330,"_331":332},"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 · v12