[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_292":293,"_294":295},"routes/_app.x.$handle.$name",{"_11":12,"_13":14,"_15":16,"_17":18,"_39":-7,"_129":-5,"_19":130,"_131":132,"_133":134,"_135":136,"_137":138,"_21":139,"_140":-5,"_141":-5,"_142":30,"_143":144,"_145":24,"_146":-5,"_147":-5,"_148":149},"routes/_app.x.$handle.$name.branch.$branch.history_.$",{"_11":12,"_13":14,"_15":16,"_17":18,"_19":20,"_21":22,"_23":24,"_25":26,"_27":28,"_29":30,"_31":-5},"handle","mosadek","name","brain-coalesce-v2-a19c","branchName","main","path","docs/superpowers/plans","project",{"_33":76,"_13":14,"_37":77,"_78":-5,"_79":30,"_80":81,"_82":81,"_83":84,"_85":-5,"_31":69,"_86":87,"_88":24,"_89":-5,"_90":-5,"_91":26,"_41":42,"_92":93,"_94":95,"_96":97,"_98":-5,"_99":100,"_101":100,"_102":103,"_104":103,"_105":103,"_106":100,"_107":100,"_54":108,"_109":110,"_111":112,"_113":30},"file",{"_64":72,"_13":73,"_67":74,"_68":30,"_75":-5},"isDirectory",true,"page",0,"history",[32],"hasNext",false,"userId",{"_33":34,"_35":36,"_37":38,"_39":40,"_41":42,"_43":44,"_45":-5,"_46":-5,"_47":-5,"_48":-5,"_49":-5,"_50":51,"_52":53,"_54":55,"_21":56,"_57":-5,"_58":-5,"_59":-5,"_60":-5,"_61":62},"id","58f5e820-bb8c-484f-93e0-c7118139d038","branchId","35b679b8-79ea-4d07-a74e-db8f3bf6ce8b","createdAt",["D",1788660318805],"version",8,"orgId","01a0715b-703f-741f-ab35-c85020e4a5e0","parentId","83323b11-951d-49f1-811b-19c5d758ac25","incomingCommitId","aiChatMessageId","aiChatThreadId","aiChatThreadUserId","aiChatThreadTitle","source","mcp","clientLabel","ChatGPT","user",{"_33":69,"_41":42,"_11":12,"_70":71},{"_64":65,"_13":66,"_67":21,"_68":30},"pull","merge","revert","multiple","commits",[63],{"_33":34,"_35":36,"_37":38,"_39":40,"_41":42,"_43":44,"_45":-5,"_46":-5,"_47":-5,"_48":-5,"_49":-5,"_50":51,"_52":53,"_54":55,"_21":56,"_57":-5,"_58":-5,"_59":-5},"fileId","68c69534-a997-11f1-acf8-1607ee4eb77e","2026-09-06-readonly-boot-coalesce-v2.md","fileType","deleted","6be0fc5c-1fef-4bd6-a1e1-67a3f8c0764e","avatar","https://lh3.googleusercontent.com/a/ACg8ocL1eT_LHhKSg5px3nXIO6eez79aZXef466qXKh2gak-0iwrvw=s96-c","67faf794-a997-11f1-9f9a-1607ee4eb77e","plans","directory","deletedAtVersion","c65dd86a-b37f-4be8-9316-7f775eeaf3a6",["D",1788660201596],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","Isolated Brain coalescer V2 repair","imageUrl","pinnedFileId","01a07474-dd3d-76da-bd7c-0da81a631649","pinPreview","pinMigrated","screenshotVersion","likeCount","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",{"_11":12,"_128":71},"org",{"_11":12,"_123":124,"_70":71,"_31":69,"_125":126,"_127":30},"branch",{"_39":114,"_13":16,"_33":36,"_115":76,"_116":-5,"_117":-5,"_118":-5,"_119":-5,"_120":-5,"_121":14,"_122":12},"isOwned",16,"projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","displayName","Mo Sadek","tier","free","canRestrictVals","profileImageUrl","adoptOrgId",{"_33":76,"_13":14,"_37":287,"_78":-5,"_79":30,"_80":81,"_82":81,"_83":84,"_85":-5,"_31":69,"_86":87,"_88":24,"_89":-5,"_90":-5,"_91":26,"_41":42,"_92":93,"_94":95,"_96":288,"_98":-5,"_99":100,"_101":100,"_102":103,"_104":103,"_105":103,"_106":100,"_107":100,"_54":289,"_109":290,"_111":291,"_113":30},"tree",[177,181,182,183,184,185,186,187,188,189,190],"files",[177,178,179,180,181,182,183,184,185,186,187,188,189,190],"counts",{"_166":26,"_167":168,"_169":26,"_170":171,"_172":173},"contents",[161],{"_33":150,"_13":73,"_64":72,"_43":151,"_35":36,"_152":153,"_154":24,"_37":155,"_39":26,"_67":74,"_156":-5,"_68":30,"_157":-5,"_17":158},"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},"528bdad7-6718-4733-80c1-7c6541423603","6738851a-a997-11f1-a117-1607ee4eb77e","branchVersion",7,"latest",["D",1788660317436],"content","label",[159,160,73],"docs","superpowers",{"_33":162,"_13":66,"_64":65,"_43":72,"_35":36,"_152":40,"_154":24,"_37":163,"_39":26,"_67":21,"_156":164,"_68":30,"_157":-5,"_17":165},"d6692aed-3dc5-4416-bfbe-a7958af7fb7f",["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",[159,160,73,66],"pulls","branches",1,"forks","envVars",{"_174":26,"_176":26},"connections",{"_174":26,"_175":26},"count","unfilledCount","emptyCount",{"_33":282,"_13":159,"_64":277,"_43":-5,"_35":36,"_152":283,"_154":24,"_37":284,"_39":26,"_67":74,"_156":-5,"_68":30,"_157":-5,"_198":285,"_17":286},{"_33":276,"_13":160,"_64":151,"_43":277,"_35":36,"_152":278,"_154":24,"_37":279,"_39":26,"_67":74,"_156":-5,"_68":30,"_157":-5,"_198":280,"_17":281},{"_33":150,"_13":73,"_64":72,"_43":151,"_35":36,"_152":153,"_154":24,"_37":273,"_39":26,"_67":74,"_156":-5,"_68":30,"_157":-5,"_198":274,"_17":275},{"_33":162,"_13":66,"_64":65,"_43":72,"_35":36,"_152":40,"_154":24,"_37":270,"_39":26,"_67":21,"_156":164,"_68":30,"_157":-5,"_198":271,"_17":272},{"_33":263,"_13":264,"_64":265,"_43":-5,"_35":36,"_152":168,"_154":24,"_37":266,"_39":26,"_67":21,"_156":267,"_68":30,"_157":-5,"_198":268,"_17":269},{"_33":256,"_13":257,"_64":258,"_43":-5,"_35":36,"_152":221,"_154":24,"_37":259,"_39":26,"_67":196,"_156":260,"_68":30,"_157":-5,"_198":261,"_17":262},{"_33":249,"_13":250,"_64":251,"_43":-5,"_35":36,"_152":221,"_154":24,"_37":252,"_39":26,"_67":196,"_156":253,"_68":30,"_157":-5,"_198":254,"_17":255},{"_33":241,"_13":242,"_64":243,"_43":-5,"_35":36,"_152":244,"_154":24,"_37":245,"_39":26,"_67":196,"_156":246,"_68":30,"_157":-5,"_198":247,"_17":248},{"_33":233,"_13":234,"_64":235,"_43":-5,"_35":36,"_152":236,"_154":24,"_37":237,"_39":26,"_67":196,"_156":238,"_68":30,"_157":-5,"_198":239,"_17":240},{"_33":225,"_13":226,"_64":87,"_43":-5,"_35":36,"_152":227,"_154":24,"_37":228,"_39":26,"_67":229,"_156":230,"_68":30,"_157":-5,"_198":231,"_17":232},{"_33":217,"_13":218,"_64":219,"_43":-5,"_35":36,"_152":114,"_154":24,"_37":220,"_39":221,"_67":196,"_156":222,"_68":30,"_157":-5,"_198":223,"_17":224},{"_33":209,"_13":210,"_64":211,"_43":-5,"_35":36,"_152":212,"_154":24,"_37":213,"_39":168,"_67":196,"_156":214,"_68":30,"_157":-5,"_198":215,"_17":216},{"_33":201,"_13":202,"_64":203,"_43":-5,"_35":36,"_152":204,"_154":24,"_37":205,"_39":168,"_67":196,"_156":206,"_68":30,"_157":-5,"_198":207,"_17":208},{"_33":191,"_13":192,"_64":193,"_43":-5,"_35":36,"_152":194,"_154":24,"_37":195,"_39":168,"_67":196,"_156":197,"_68":30,"_157":-5,"_198":199,"_17":200},"7f5e8787-9e3e-4d5b-86b7-09983217a732","coalesce_v2_regression_test.ts","b46196a6-a997-11f1-adb7-1607ee4eb77e",12,["D",1788660555259],"script","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}`); }","children",[],[192],"a916aeb9-81db-4cba-9a50-cf1b56170489","coalesce_e72c_order_test.ts","01a07474-d845-763b-8ed2-493754878221",15,["D",1788660577506],"import { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\nimport { coalesceFollowersSql, mayCoalesceSuccessfulLeader } from \"./brain_bridge_readonly_coalesce_v2_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}",[],[202],"b5e0a034-0310-4c88-b1ed-5bb5a3226a44","coalesce_e72c_boundary_test.ts","01a07474-d845-763b-8ed2-4449ec6bcf0e",14,["D",1788660576250],"import { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\nimport { coalesceFollowersSql, mayCoalesceSuccessfulLeader } 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=\"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}",[],[210],"44fdc192-d9c1-4830-85db-cce992b8bffc","coalesce_e72c_adv_test.ts","01a07474-d845-763b-8ed2-41a6d012e16c",["D",1788660653006],2,"import { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\nimport {\n coalesceFollowersSql,\n mayCoalesceSuccessfulLeader,\n readonlyBrainCommand,\n} from \"./brain_bridge_readonly_coalesce_v2_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\",\"2099-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\",\"2099-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\",\"2099-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\",\"2099-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\",\"2099-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",[],[218],"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",[],[226],"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}",[],[234],"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",[],[242],"51b92974-5757-4047-9f8a-6a6bb801f3b2","brain_bridge_readonly_coalesce_v1_test.ts","01a07474-d2f9-700b-b98b-525025b02d85",["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}",[],[250],"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",[],[257],"6f75015b-5ec1-4e22-bc81-5914eda752a3","README.md","22efdef8-a997-11f1-b55c-1607ee4eb77e",["D",1788660201636],"# Brain Coalescer V2 A19C\n\nIsolated nonauthority repair workspace.\n",[],[264],["D",1788660318805],[],[159,160,73,66],["D",1788660317436],[180],[159,160,73],"280ec4e5-d943-4e88-b11c-f2a553b35ad2","6659917a-a997-11f1-9514-1607ee4eb77e",6,["D",1788660316198],[179],[159,160],"226ee7b5-14d7-43f9-a99f-6033beb98aba",5,["D",1788660314741],[178],[159],["D",1788660201596],["D",1789533091345],{"_11":12,"_128":71},{"_11":12,"_123":124,"_70":71,"_31":69,"_125":126,"_127":30},{"_39":114,"_13":16,"_33":36,"_115":76,"_116":-5,"_117":-5,"_118":-5,"_119":-5,"_120":-5,"_121":14,"_122":12},"ctx",{"_54":-5,"_147":325,"_326":327,"_328":329,"_330":30,"_331":30,"_332":30,"_333":24,"_334":-5,"_335":-7,"_336":-7,"_337":26,"_338":30,"_339":30,"_340":-5,"_341":30,"_342":30,"_343":30,"_344":-5},"ENV",{"_296":297,"_298":299,"_300":16,"_301":302,"_303":304,"_305":306,"_307":308,"_309":310,"_311":312,"_313":314,"_315":316,"_317":318,"_319":320,"_321":322,"_323":324},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","RENDER_GIT_COMMIT","fdb67791413f4386b4dbf18f354029a617f6160f","RENDER_GIT_BRANCH","POSTHOG_API_TOKEN","phc_nmoyuAkStEZuUp69rYlg1DZgrIt19Gx0Y4Hwf8tGgJP","POSTHOG_API_HOST","https://wart.val.town","WEB_API_TEMPLATE","https://{val}.web.val.run","APP_URL","https://www.val.town","MODULE_URL","https://esm.town","VANITY_WEB_API_TEMPLATE","https://{label}.val.run/","DENOLS_URL","https://lsp.val.town","NODE_ENV","production","CLOUDFLARE_TURNSTILE_SITE_KEY","0x4AAAAAACtaIZJH7s9rBMZ6","GOOGLE_CLIENT_ID","875989696899-jtsqkhlbdv5jrlsk8631p7ipjg3c6o62.apps.googleusercontent.com","STRIPE_PUBLISHABLE_KEY","pk_live_51N2zvWEpZTTLipIkVEwXrUG9AT0yeOOEYxszarZT1jpsZV58Ly6wlg3SltZpHN26CUalOBmUSY7adQRQiSkCZz2500qSXNkf8Y","API_URL","https://api.val.town",[],"preferencesKeybindings","default","preferencesTheme","light","preferencesFixers","preferencesCopilot","preferencesSelectionAi","preferencesCloseBrackets","preferencesChatPanelState","preferencesDprint","preferencesDenofmt","notificationCount","flagDenols","isBusinessOrgMember","businessOrgHandle","isBusinessOrgAdmin","isHigherTownieTier","navCollapsed","currentOrgId"]

History · plans