[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_263":264,"_265":266},"routes/_app.x.$handle.$name",{"_98":97,"_31":43,"_107":88,"_26":108,"_13":14,"_109":-5,"_11":110,"_111":112,"_113":114,"_115":116,"_117":118,"_20":-5,"_119":-5,"_120":-5,"_121":24,"_122":123,"_124":57,"_125":-5,"_126":-5,"_127":128},"routes/_app.x.$handle.$name.branch.$branch.version.$version.diff",{"_11":12,"_13":14,"_15":16,"_17":-5,"_18":-5},"project",{"_41":42,"_31":43,"_36":44,"_45":-5,"_46":24,"_47":48,"_49":48,"_50":51,"_52":-5,"_18":53,"_54":55,"_56":57,"_58":-5,"_59":-5,"_60":61,"_62":63,"_64":65,"_66":67,"_68":69,"_70":-5,"_71":72,"_73":72,"_74":75,"_76":75,"_77":75,"_78":72,"_79":72,"_80":81,"_82":83,"_84":85,"_86":24},"version",8,"changes",[19],"aiChatInfo","userId",{"_20":21,"_22":-7,"_23":24,"_25":24,"_26":27,"_28":27},"file",{"_29":30,"_31":32,"_33":20,"_34":35,"_36":37,"_38":14,"_39":40,"_23":24},"previous","deleted",false,"deletedHere","path","docs/superpowers/plans/2026-09-06-readonly-boot-coalesce-v2.md","latestPath","fileId","68c69534-a997-11f1-acf8-1607ee4eb77e","name","2026-09-06-readonly-boot-coalesce-v2.md","fileType","content","# 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","createdAt",["D",1788660318805],"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",{"_98":97,"_106":102},"org",{"_98":97,"_99":100,"_101":102,"_18":53,"_103":104,"_105":24},"branch",{"_13":87,"_31":88,"_41":40,"_89":42,"_90":-5,"_91":-5,"_92":-5,"_93":-5,"_94":-5,"_95":43,"_96":97},"isOwned",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",{"_41":42,"_31":43,"_36":258,"_45":-5,"_46":24,"_47":48,"_49":48,"_50":51,"_52":-5,"_18":53,"_54":55,"_56":57,"_58":-5,"_59":-5,"_60":61,"_62":63,"_64":65,"_66":67,"_68":259,"_70":-5,"_71":72,"_73":72,"_74":75,"_76":75,"_77":75,"_78":72,"_79":72,"_80":260,"_82":261,"_84":262,"_86":24},"tree",[204,208,209,210,211,212,213,214],"files",[204,205,206,207,208,209,210,211,212,213,214],"counts",{"_194":61,"_195":183,"_196":61,"_197":198,"_199":200},"contents",[129,130,131,132,133,134,135,136],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},{"_41":187,"_31":188,"_29":189,"_140":-5,"_39":40,"_38":190,"_142":57,"_36":191,"_13":61,"_33":192,"_34":-5,"_23":24,"_146":-5,"_26":193},{"_41":180,"_31":181,"_29":182,"_140":-5,"_39":40,"_38":183,"_142":57,"_36":184,"_13":61,"_33":20,"_34":185,"_23":24,"_146":-5,"_26":186},{"_41":174,"_31":175,"_29":176,"_140":-5,"_39":40,"_38":170,"_142":57,"_36":177,"_13":61,"_33":144,"_34":178,"_23":24,"_146":-5,"_26":179},{"_41":167,"_31":168,"_29":169,"_140":-5,"_39":40,"_38":170,"_142":57,"_36":171,"_13":61,"_33":144,"_34":172,"_23":24,"_146":-5,"_26":173},{"_41":160,"_31":161,"_29":55,"_140":-5,"_39":40,"_38":162,"_142":57,"_36":163,"_13":61,"_33":164,"_34":165,"_23":24,"_146":-5,"_26":166},{"_41":154,"_31":155,"_29":156,"_140":-5,"_39":40,"_38":141,"_142":24,"_36":157,"_13":61,"_33":144,"_34":158,"_23":24,"_146":-5,"_26":159},{"_41":148,"_31":149,"_29":150,"_140":-5,"_39":40,"_38":141,"_142":24,"_36":151,"_13":61,"_33":144,"_34":152,"_23":24,"_146":-5,"_26":153},{"_41":137,"_31":138,"_29":139,"_140":-5,"_39":40,"_38":141,"_142":24,"_36":143,"_13":61,"_33":144,"_34":145,"_23":24,"_146":-5,"_26":147},"636a5518-29ae-40f9-8c2c-b5a90db9f8da","coalesce_e72c_order_test.ts","01a07474-d845-763b-8ed2-493754878221","parentId",3,"latest",["D",1788660209734],"script","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}","label",[138],"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}",[149],"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",[155],"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",[161],"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}",[168],"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",[175],"6f75015b-5ec1-4e22-bc81-5914eda752a3","README.md","22efdef8-a997-11f1-b55c-1607ee4eb77e",1,["D",1788660201636],"# Brain Coalescer V2 A19C\n\nIsolated nonauthority repair workspace.\n",[181],"226ee7b5-14d7-43f9-a99f-6033beb98aba","docs","6659917a-a997-11f1-9514-1607ee4eb77e",5,["D",1788660314741],"directory",[188],"pulls","branches","forks","envVars",{"_201":61,"_203":61},"connections",{"_201":61,"_202":61},"count","unfilledCount","emptyCount",{"_41":187,"_31":188,"_29":189,"_140":-5,"_39":40,"_38":190,"_142":57,"_36":255,"_13":61,"_33":192,"_34":-5,"_23":24,"_146":-5,"_216":256,"_26":257},{"_41":250,"_31":242,"_29":245,"_140":189,"_39":40,"_38":251,"_142":57,"_36":252,"_13":61,"_33":192,"_34":-5,"_23":24,"_146":-5,"_216":253,"_26":254},{"_41":244,"_31":243,"_29":238,"_140":245,"_39":40,"_38":246,"_142":57,"_36":247,"_13":61,"_33":192,"_34":-5,"_23":24,"_146":-5,"_216":248,"_26":249},{"_41":237,"_31":32,"_29":30,"_140":238,"_39":40,"_38":14,"_142":57,"_36":239,"_13":61,"_33":20,"_34":35,"_23":24,"_146":-5,"_216":240,"_26":241},{"_41":180,"_31":181,"_29":182,"_140":-5,"_39":40,"_38":183,"_142":57,"_36":234,"_13":61,"_33":20,"_34":185,"_23":24,"_146":-5,"_216":235,"_26":236},{"_41":174,"_31":175,"_29":176,"_140":-5,"_39":40,"_38":170,"_142":57,"_36":231,"_13":61,"_33":144,"_34":178,"_23":24,"_146":-5,"_216":232,"_26":233},{"_41":167,"_31":168,"_29":169,"_140":-5,"_39":40,"_38":170,"_142":57,"_36":228,"_13":61,"_33":144,"_34":172,"_23":24,"_146":-5,"_216":229,"_26":230},{"_41":160,"_31":161,"_29":55,"_140":-5,"_39":40,"_38":162,"_142":57,"_36":225,"_13":61,"_33":164,"_34":165,"_23":24,"_146":-5,"_216":226,"_26":227},{"_41":154,"_31":155,"_29":156,"_140":-5,"_39":40,"_38":141,"_142":24,"_36":222,"_13":61,"_33":144,"_34":158,"_23":24,"_146":-5,"_216":223,"_26":224},{"_41":148,"_31":149,"_29":150,"_140":-5,"_39":40,"_38":141,"_142":24,"_36":219,"_13":61,"_33":144,"_34":152,"_23":24,"_146":-5,"_216":220,"_26":221},{"_41":137,"_31":138,"_29":139,"_140":-5,"_39":40,"_38":141,"_142":24,"_36":215,"_13":61,"_33":144,"_34":145,"_23":24,"_146":-5,"_216":217,"_26":218},["D",1788660209734],"children",[],[138],["D",1788660209734],[],[149],["D",1788660209734],[],[155],["D",1788660211007],[],[161],["D",1788660208378],[],[168],["D",1788660208378],[],[175],["D",1788660201636],[],[181],"d6692aed-3dc5-4416-bfbe-a7958af7fb7f","67faf794-a997-11f1-9f9a-1607ee4eb77e",["D",1788660318805],[],[188,242,243,32],"superpowers","plans","528bdad7-6718-4733-80c1-7c6541423603","6738851a-a997-11f1-a117-1607ee4eb77e",7,["D",1788660317436],[207],[188,242,243],"280ec4e5-d943-4e88-b11c-f2a553b35ad2",6,["D",1788660316198],[206],[188,242],["D",1788660314741],[205],[188],["D",1788660201596],["D",1789533091345],{"_98":97,"_106":102},{"_98":97,"_99":100,"_101":102,"_18":53,"_103":104,"_105":24},{"_13":87,"_31":88,"_41":40,"_89":42,"_90":-5,"_91":-5,"_92":-5,"_93":-5,"_94":-5,"_95":43,"_96":97},"ctx",{"_80":-5,"_126":296,"_297":298,"_299":300,"_301":24,"_302":24,"_303":24,"_304":57,"_305":-5,"_306":-7,"_307":-7,"_308":61,"_309":24,"_310":24,"_311":-5,"_312":24,"_313":24,"_314":24,"_315":-5},"ENV",{"_267":268,"_269":270,"_271":88,"_272":273,"_274":275,"_276":277,"_278":279,"_280":281,"_282":283,"_284":285,"_286":287,"_288":289,"_290":291,"_292":293,"_294":295},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","RENDER_GIT_COMMIT","e87eb04e707cf64e7e532c8e8ec395f209e17f15","RENDER_GIT_BRANCH","POSTHOG_API_TOKEN","phc_nmoyuAkStEZuUp69rYlg1DZgrIt19Gx0Y4Hwf8tGgJP","POSTHOG_API_HOST","https://wart.val.town","WEB_API_TEMPLATE","https://{val}.web.val.run","APP_URL","https://www.val.town","MODULE_URL","https://esm.town","VANITY_WEB_API_TEMPLATE","https://{label}.val.run/","DENOLS_URL","https://lsp.val.town","NODE_ENV","production","CLOUDFLARE_TURNSTILE_SITE_KEY","0x4AAAAAACtaIZJH7s9rBMZ6","GOOGLE_CLIENT_ID","875989696899-jtsqkhlbdv5jrlsk8631p7ipjg3c6o62.apps.googleusercontent.com","STRIPE_PUBLISHABLE_KEY","pk_live_51N2zvWEpZTTLipIkVEwXrUG9AT0yeOOEYxszarZT1jpsZV58Ly6wlg3SltZpHN26CUalOBmUSY7adQRQiSkCZz2500qSXNkf8Y","API_URL","https://api.val.town",[],"preferencesKeybindings","default","preferencesTheme","light","preferencesFixers","preferencesCopilot","preferencesSelectionAi","preferencesCloseBrackets","preferencesChatPanelState","preferencesDprint","preferencesDenofmt","notificationCount","flagDenols","isBusinessOrgMember","businessOrgHandle","isBusinessOrgAdmin","isHigherTownieTier","navCollapsed","currentOrgId"]

Diff · v8