[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_217":218,"_219":220},"routes/_app.x.$handle.$name",{"_98":97,"_32":45,"_107":88,"_27":108,"_13":14,"_109":-5,"_11":110,"_111":112,"_113":114,"_115":116,"_117":118,"_20":-5,"_119":-5,"_120":-5,"_121":25,"_122":123,"_124":25,"_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",{"_43":44,"_32":45,"_38":46,"_47":-5,"_48":25,"_49":50,"_51":50,"_52":53,"_54":-5,"_18":55,"_56":-5,"_57":25,"_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":25},"version",9,"changes",[19],"aiChatInfo","userId",{"_20":21,"_22":23,"_24":25,"_26":25,"_27":28,"_29":28},"file",{"_30":31,"_32":28,"_33":34,"_35":37,"_38":39,"_40":14,"_41":42,"_24":25},"previous",{"_30":31,"_32":28,"_33":34,"_35":36},"deleted",false,"deletedHere","path","current_kernel_atomicity_test.ts","latestPath","fileId","ea3915e2-aaaf-11f1-939d-1607ee4eb77e","name","fileType","script","content","import { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\nimport { dispatchBrain } from \"./val_native_kernel_atomic_candidate.ts\";\n\nconst P=\"brainvn_\";\nconst pred=\"b\".repeat(64);\nconst now=()=>new Date().toISOString().replace(\"Z\",\"+00:00\");\nasync function one(sql:string,args:any[]=[]){return (await sqlite.execute({sql,args})).rows?.[0]??null}\nasync function reset(){\n for(const t of [\"task_invariant_history\",\"task_context_history\",\"replicas\",\"artifacts\",\"claim_deps\",\"claims\",\"tasks\",\"agents\",\"workstreams\",\"epoch_events\",\"epoch_meta\"])await sqlite.execute(`DROP TABLE IF EXISTS ${P}${t}`);\n await sqlite.execute(`CREATE TABLE ${P}epoch_meta(id INTEGER PRIMARY KEY CHECK(id=1),epoch INTEGER NOT NULL,predecessor_generation INTEGER NOT NULL,predecessor_event_count INTEGER NOT NULL,predecessor_head TEXT NOT NULL,generation INTEGER NOT NULL,event_head_hash TEXT NOT NULL,new_event_count INTEGER NOT NULL,recovered_count INTEGER NOT NULL,ordering_policy TEXT NOT NULL,classification TEXT NOT NULL,created_at TEXT NOT NULL)`);\n await sqlite.execute(`CREATE TABLE ${P}epoch_events(local_seq INTEGER PRIMARY KEY,event_uuid TEXT UNIQUE NOT NULL,ts TEXT NOT NULL,workstream TEXT NOT NULL,agent_id TEXT,task_id TEXT,type TEXT NOT NULL,payload_json TEXT NOT NULL,prev_hash TEXT NOT NULL,event_hash TEXT UNIQUE NOT NULL,transaction_generation INTEGER NOT NULL)`);\n await sqlite.execute(`CREATE TABLE ${P}workstreams(id TEXT PRIMARY KEY,mission TEXT NOT NULL,head_generation INTEGER NOT NULL,verified_state TEXT NOT NULL,updated_at TEXT NOT NULL)`);\n await sqlite.execute(`CREATE TABLE ${P}agents(id TEXT PRIMARY KEY,parent_id TEXT,type TEXT NOT NULL,workstream TEXT NOT NULL,role TEXT NOT NULL,status TEXT NOT NULL,boot_generation INTEGER NOT NULL,last_generation INTEGER NOT NULL,last_seen TEXT NOT NULL,capabilities_json TEXT NOT NULL)`);\n await sqlite.execute(`CREATE TABLE ${P}tasks(id TEXT PRIMARY KEY,workstream TEXT NOT NULL,state TEXT NOT NULL,priority REAL NOT NULL,depends_json TEXT NOT NULL,success_condition TEXT NOT NULL,decision_value TEXT NOT NULL,context_manifest TEXT NOT NULL,lease_owner TEXT,lease_mode TEXT,lease_generation INTEGER,lease_expires_at TEXT,created_at TEXT NOT NULL,updated_at TEXT NOT NULL,result_event_id INTEGER,requires_json TEXT NOT NULL,dedupe_key TEXT,assigned_agent TEXT,delegated_by TEXT,writes_json TEXT NOT NULL,guards_json TEXT NOT NULL)`);\n await sqlite.execute(`CREATE TABLE ${P}claims(id TEXT PRIMARY KEY,workstream TEXT NOT NULL,status TEXT NOT NULL,statement_json TEXT NOT NULL,statement_sha256 TEXT NOT NULL,evidence_json TEXT NOT NULL,created_generation INTEGER NOT NULL,invalidated_by TEXT,created_at TEXT NOT NULL,updated_at TEXT NOT NULL)`);\n await sqlite.execute(`CREATE TABLE ${P}claim_deps(parent_claim TEXT NOT NULL,child_claim TEXT NOT NULL,PRIMARY KEY(parent_claim,child_claim))`);\n await sqlite.execute(`CREATE TABLE ${P}artifacts(sha256 TEXT PRIMARY KEY,size INTEGER NOT NULL,logical_name TEXT,producer_agent TEXT,task_id TEXT,storage_json TEXT NOT NULL,created_at TEXT NOT NULL)`);\n await sqlite.execute(`CREATE TABLE ${P}replicas(id INTEGER PRIMARY KEY,generation INTEGER NOT NULL,provider TEXT NOT NULL,uri TEXT NOT NULL,snapshot_sha256 TEXT NOT NULL,event_head_hash TEXT NOT NULL,verified INTEGER NOT NULL,created_at TEXT NOT NULL)`);\n await sqlite.execute(`CREATE TABLE ${P}task_context_history(id INTEGER PRIMARY KEY,task_id TEXT NOT NULL,version INTEGER NOT NULL,old_context_json TEXT NOT NULL,new_context_json TEXT NOT NULL,reason TEXT NOT NULL,evidence_json TEXT NOT NULL,agent_id TEXT,event_id INTEGER NOT NULL,created_at TEXT NOT NULL)`);\n await sqlite.execute(`CREATE TABLE ${P}task_invariant_history(id INTEGER PRIMARY KEY,task_id TEXT NOT NULL,version INTEGER NOT NULL,old_dedupe_key TEXT,new_dedupe_key TEXT NOT NULL,old_writes_json TEXT NOT NULL,new_writes_json TEXT NOT NULL,old_guards_json TEXT NOT NULL,new_guards_json TEXT NOT NULL,reason TEXT NOT NULL,evidence_json TEXT NOT NULL,agent_id TEXT,event_id INTEGER NOT NULL,created_at TEXT NOT NULL)`);\n await sqlite.batch([\n {sql:`INSERT INTO ${P}epoch_meta VALUES(1,3,100,500,?,100,?,0,0,'TEST','DISPOSABLE',?)`,args:[pred,pred,now()]},\n {sql:`INSERT INTO ${P}workstreams VALUES('global','test',100,'{}',?)`,args:[now()]},\n {sql:`INSERT INTO ${P}tasks VALUES('T1','global','READY',1000,'[]','done','value','{}',NULL,NULL,NULL,NULL,?,?,NULL,'[]','t1',NULL,NULL,'[]','[]')`,args:[now(),now()]},\n {sql:`INSERT INTO ${P}tasks VALUES('T2','global','READY',900,'[]','done2','value2','{}',NULL,NULL,NULL,NULL,?,?,NULL,'[]','t2',NULL,NULL,'[]','[]')`,args:[now(),now()]}\n ]);\n}\nconst payload=(args:string[])=>JSON.stringify({args,timeout:60});\nasync function snap(){return {meta:await one(`SELECT * FROM ${P}epoch_meta WHERE id=1`),events:Number((await one(`SELECT COUNT(*) n FROM ${P}epoch_events`)).n),agents:Number((await one(`SELECT COUNT(*) n FROM ${P}agents`)).n),t1:await one(`SELECT state,lease_owner,lease_generation,result_event_id FROM ${P}tasks WHERE id='T1'`),t2:await one(`SELECT state,lease_owner,lease_generation,result_event_id FROM ${P}tasks WHERE id='T2'`)}}\nawait reset();\nconst caps=JSON.stringify([\"file_analysis\",\"val_town_blob\",\"val_town_write\"]);\nconst reg=(id:string)=>payload([\"register-agent\",id,\"--workstream\",\"global\",\"--role\",\"fixture\",\"--type\",\"CHAT\",\"--capabilities\",caps]);\nconst obs:any={};\nawait sqlite.execute(`CREATE TRIGGER inj_reg BEFORE UPDATE ON ${P}epoch_meta WHEN NEW.generation>OLD.generation BEGIN SELECT RAISE(ABORT,'INJECT_REG_POST_EVENT'); END`);\ntry{obs.regCrash=await dispatchBrain(reg(\"X\"))}catch(e){obs.regCrash={error:String((e as Error).message)}}\nawait sqlite.execute(`DROP TRIGGER inj_reg`);\nobs.afterRegCrash=await snap();\nobs.regA=await dispatchBrain(reg(\"A\"));\nobs.regB=await dispatchBrain(reg(\"B\"));\nconst beforeClaim=await snap();\nawait sqlite.execute(`CREATE TRIGGER inj_claim BEFORE UPDATE ON ${P}agents WHEN NEW.status='WORKING' BEGIN SELECT RAISE(ABORT,'INJECT_CLAIM_POST_EVENT'); END`);\ntry{obs.claimCrash=await dispatchBrain(payload([\"claim\",\"--agent\",\"A\",\"--mode\",\"INTERACTIVE\",\"--lease-seconds\",\"900\"]))}catch(e){obs.claimCrash={error:String((e as Error).message)}}\nawait sqlite.execute(`DROP TRIGGER inj_claim`);\nobs.afterClaimCrash=await snap();\nobs.claimA=await dispatchBrain(payload([\"claim\",\"--agent\",\"A\",\"--mode\",\"INTERACTIVE\",\"--lease-seconds\",\"900\"]));\nconst beforeCommit=await snap();\nawait sqlite.execute(`CREATE TRIGGER inj_commit BEFORE UPDATE ON ${P}tasks WHEN NEW.state='COMPLETE' BEGIN SELECT RAISE(ABORT,'INJECT_COMMIT_POST_EVENT'); END`);\ntry{obs.commitCrash=await dispatchBrain(payload([\"commit\",\"--agent\",\"A\",\"--task\",\"T1\",\"--expected-workstream-generation\",String(obs.claimA.workstream_generation),\"--state\",\"COMPLETE\",\"--payload\",JSON.stringify({result:\"PASS\"})]))}catch(e){obs.commitCrash={error:String((e as Error).message)}}\nawait sqlite.execute(`DROP TRIGGER inj_commit`);\nobs.afterCommitCrash=await snap();\nobs.commitA=await dispatchBrain(payload([\"commit\",\"--agent\",\"A\",\"--task\",\"T1\",\"--expected-workstream-generation\",String(obs.claimA.workstream_generation),\"--state\",\"COMPLETE\",\"--payload\",JSON.stringify({result:\"PASS\"})]));\nconst good=await dispatchBrain(payload([\"verify-chain\"]));const realHead=good.computed_head;\nawait sqlite.execute({sql:`UPDATE ${P}epoch_meta SET event_head_hash='BROKEN' WHERE id=1`});\ntry{obs.staleParent=await dispatchBrain(reg(\"E\"))}catch(e){obs.staleParent={error:String((e as Error).message)}}\nobs.eAfterStale=await one(`SELECT id FROM ${P}agents WHERE id='E'`);\nawait sqlite.execute({sql:`UPDATE ${P}epoch_meta SET event_head_hash=? WHERE id=1`,args:[realHead]});\nobs.concurrentRegs=await Promise.all([dispatchBrain(reg(\"C\")),dispatchBrain(reg(\"D\"))]);\nobs.claimRace=await Promise.all([\n dispatchBrain(payload([\"claim\",\"--agent\",\"B\",\"--mode\",\"INTERACTIVE\",\"--lease-seconds\",\"900\"])),\n dispatchBrain(payload([\"claim\",\"--agent\",\"C\",\"--mode\",\"INTERACTIVE\",\"--lease-seconds\",\"900\"]))\n]);\nobs.finalChain=await dispatchBrain(payload([\"verify-chain\"]));\nobs.finalGraph=await dispatchBrain(payload([\"verify-claim-graph\"]));\nobs.final=await snap();\nconst same=(a:any,b:any)=>JSON.stringify(a)===JSON.stringify(b);\nconst pass=\n !!obs.regCrash.error&&obs.afterRegCrash.agents===0&&obs.afterRegCrash.events===0&&Number(obs.afterRegCrash.meta.generation)===100&&\n !!obs.claimCrash.error&&same(beforeClaim,obs.afterClaimCrash)&&\n !!obs.commitCrash.error&&same(beforeCommit,obs.afterCommitCrash)&&\n !!obs.staleParent.error&&!obs.eAfterStale&&\n obs.concurrentRegs.every((x:any)=>x.ok)&&\n obs.claimRace.filter((x:any)=>x.ok).length===1&&\n obs.finalChain.ok&&obs.finalGraph.ok;\nconst receipt={schema:\"BRAIN_CURRENT_KERNEL_ASYNCLOCAL_COMMAND_ATOMICITY_FALSIFICATION_V1\",classification:\"NONAUTHORITY_DISPOSABLE_TEST\",obs,pass,direct_sprites_calls:0,human_authority_approval:false};\nconsole.log(JSON.stringify(receipt,null,2));\n","import { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\nimport { dispatchBrain } from \"./val_native_kernel_quarantine_candidate.ts\";\n\nconst P=\"brainvn_\";\nconst pred=\"b\".repeat(64);\nconst now=()=>new Date().toISOString().replace(\"Z\",\"+00:00\");\nasync function one(sql:string,args:any[]=[]){return (await sqlite.execute({sql,args})).rows?.[0]??null}\nasync function reset(){\n for(const t of [\"task_invariant_history\",\"task_context_history\",\"replicas\",\"artifacts\",\"claim_deps\",\"claims\",\"tasks\",\"agents\",\"workstreams\",\"epoch_events\",\"epoch_meta\"])await sqlite.execute(`DROP TABLE IF EXISTS ${P}${t}`);\n await sqlite.execute(`CREATE TABLE ${P}epoch_meta(id INTEGER PRIMARY KEY CHECK(id=1),epoch INTEGER NOT NULL,predecessor_generation INTEGER NOT NULL,predecessor_event_count INTEGER NOT NULL,predecessor_head TEXT NOT NULL,generation INTEGER NOT NULL,event_head_hash TEXT NOT NULL,new_event_count INTEGER NOT NULL,recovered_count INTEGER NOT NULL,ordering_policy TEXT NOT NULL,classification TEXT NOT NULL,created_at TEXT NOT NULL)`);\n await sqlite.execute(`CREATE TABLE ${P}epoch_events(local_seq INTEGER PRIMARY KEY,event_uuid TEXT UNIQUE NOT NULL,ts TEXT NOT NULL,workstream TEXT NOT NULL,agent_id TEXT,task_id TEXT,type TEXT NOT NULL,payload_json TEXT NOT NULL,prev_hash TEXT NOT NULL,event_hash TEXT UNIQUE NOT NULL,transaction_generation INTEGER NOT NULL)`);\n await sqlite.execute(`CREATE TABLE ${P}workstreams(id TEXT PRIMARY KEY,mission TEXT NOT NULL,head_generation INTEGER NOT NULL,verified_state TEXT NOT NULL,updated_at TEXT NOT NULL)`);\n await sqlite.execute(`CREATE TABLE ${P}agents(id TEXT PRIMARY KEY,parent_id TEXT,type TEXT NOT NULL,workstream TEXT NOT NULL,role TEXT NOT NULL,status TEXT NOT NULL,boot_generation INTEGER NOT NULL,last_generation INTEGER NOT NULL,last_seen TEXT NOT NULL,capabilities_json TEXT NOT NULL)`);\n await sqlite.execute(`CREATE TABLE ${P}tasks(id TEXT PRIMARY KEY,workstream TEXT NOT NULL,state TEXT NOT NULL,priority REAL NOT NULL,depends_json TEXT NOT NULL,success_condition TEXT NOT NULL,decision_value TEXT NOT NULL,context_manifest TEXT NOT NULL,lease_owner TEXT,lease_mode TEXT,lease_generation INTEGER,lease_expires_at TEXT,created_at TEXT NOT NULL,updated_at TEXT NOT NULL,result_event_id INTEGER,requires_json TEXT NOT NULL,dedupe_key TEXT,assigned_agent TEXT,delegated_by TEXT,writes_json TEXT NOT NULL,guards_json TEXT NOT NULL)`);\n await sqlite.execute(`CREATE TABLE ${P}claims(id TEXT PRIMARY KEY,workstream TEXT NOT NULL,status TEXT NOT NULL,statement_json TEXT NOT NULL,statement_sha256 TEXT NOT NULL,evidence_json TEXT NOT NULL,created_generation INTEGER NOT NULL,invalidated_by TEXT,created_at TEXT NOT NULL,updated_at TEXT NOT NULL)`);\n await sqlite.execute(`CREATE TABLE ${P}claim_deps(parent_claim TEXT NOT NULL,child_claim TEXT NOT NULL,PRIMARY KEY(parent_claim,child_claim))`);\n await sqlite.execute(`CREATE TABLE ${P}artifacts(sha256 TEXT PRIMARY KEY,size INTEGER NOT NULL,logical_name TEXT,producer_agent TEXT,task_id TEXT,storage_json TEXT NOT NULL,created_at TEXT NOT NULL)`);\n await sqlite.execute(`CREATE TABLE ${P}replicas(id INTEGER PRIMARY KEY,generation INTEGER NOT NULL,provider TEXT NOT NULL,uri TEXT NOT NULL,snapshot_sha256 TEXT NOT NULL,event_head_hash TEXT NOT NULL,verified INTEGER NOT NULL,created_at TEXT NOT NULL)`);\n await sqlite.execute(`CREATE TABLE ${P}task_context_history(id INTEGER PRIMARY KEY,task_id TEXT NOT NULL,version INTEGER NOT NULL,old_context_json TEXT NOT NULL,new_context_json TEXT NOT NULL,reason TEXT NOT NULL,evidence_json TEXT NOT NULL,agent_id TEXT,event_id INTEGER NOT NULL,created_at TEXT NOT NULL)`);\n await sqlite.execute(`CREATE TABLE ${P}task_invariant_history(id INTEGER PRIMARY KEY,task_id TEXT NOT NULL,version INTEGER NOT NULL,old_dedupe_key TEXT,new_dedupe_key TEXT NOT NULL,old_writes_json TEXT NOT NULL,new_writes_json TEXT NOT NULL,old_guards_json TEXT NOT NULL,new_guards_json TEXT NOT NULL,reason TEXT NOT NULL,evidence_json TEXT NOT NULL,agent_id TEXT,event_id INTEGER NOT NULL,created_at TEXT NOT NULL)`);\n await sqlite.batch([\n {sql:`INSERT INTO ${P}epoch_meta VALUES(1,3,100,500,?,100,?,0,0,'TEST','DISPOSABLE',?)`,args:[pred,pred,now()]},\n {sql:`INSERT INTO ${P}workstreams VALUES('global','test',100,'{}',?)`,args:[now()]},\n {sql:`INSERT INTO ${P}tasks VALUES('T1','global','READY',1000,'[]','done','value','{}',NULL,NULL,NULL,NULL,?,?,NULL,'[]','t1',NULL,NULL,'[]','[]')`,args:[now(),now()]},\n {sql:`INSERT INTO ${P}tasks VALUES('T2','global','READY',900,'[]','done2','value2','{}',NULL,NULL,NULL,NULL,?,?,NULL,'[]','t2',NULL,NULL,'[]','[]')`,args:[now(),now()]}\n ]);\n}\nconst payload=(args:string[])=>JSON.stringify({args,timeout:60});\nasync function snap(){return {meta:await one(`SELECT * FROM ${P}epoch_meta WHERE id=1`),events:Number((await one(`SELECT COUNT(*) n FROM ${P}epoch_events`)).n),agents:Number((await one(`SELECT COUNT(*) n FROM ${P}agents`)).n),t1:await one(`SELECT state,lease_owner,lease_generation,result_event_id FROM ${P}tasks WHERE id='T1'`),t2:await one(`SELECT state,lease_owner,lease_generation,result_event_id FROM ${P}tasks WHERE id='T2'`)}}\nawait reset();\nconst caps=JSON.stringify([\"file_analysis\",\"val_town_blob\",\"val_town_write\"]);\nconst reg=(id:string)=>payload([\"register-agent\",id,\"--workstream\",\"global\",\"--role\",\"fixture\",\"--type\",\"CHAT\",\"--capabilities\",caps]);\nconst obs:any={};\nawait sqlite.execute(`CREATE TRIGGER inj_reg BEFORE UPDATE ON ${P}epoch_meta WHEN NEW.generation>OLD.generation BEGIN SELECT RAISE(ABORT,'INJECT_REG_POST_EVENT'); END`);\ntry{obs.regCrash=await dispatchBrain(reg(\"X\"))}catch(e){obs.regCrash={error:String((e as Error).message)}}\nawait sqlite.execute(`DROP TRIGGER inj_reg`);\nobs.afterRegCrash=await snap();\nobs.regA=await dispatchBrain(reg(\"A\"));\nobs.regB=await dispatchBrain(reg(\"B\"));\nconst beforeClaim=await snap();\nawait sqlite.execute(`CREATE TRIGGER inj_claim BEFORE UPDATE ON ${P}agents WHEN NEW.status='WORKING' BEGIN SELECT RAISE(ABORT,'INJECT_CLAIM_POST_EVENT'); END`);\ntry{obs.claimCrash=await dispatchBrain(payload([\"claim\",\"--agent\",\"A\",\"--mode\",\"INTERACTIVE\",\"--lease-seconds\",\"900\"]))}catch(e){obs.claimCrash={error:String((e as Error).message)}}\nawait sqlite.execute(`DROP TRIGGER inj_claim`);\nobs.afterClaimCrash=await snap();\nobs.claimA=await dispatchBrain(payload([\"claim\",\"--agent\",\"A\",\"--mode\",\"INTERACTIVE\",\"--lease-seconds\",\"900\"]));\nconst beforeCommit=await snap();\nawait sqlite.execute(`CREATE TRIGGER inj_commit BEFORE UPDATE ON ${P}tasks WHEN NEW.state='COMPLETE' BEGIN SELECT RAISE(ABORT,'INJECT_COMMIT_POST_EVENT'); END`);\ntry{obs.commitCrash=await dispatchBrain(payload([\"commit\",\"--agent\",\"A\",\"--task\",\"T1\",\"--expected-workstream-generation\",String(obs.claimA.workstream_generation),\"--state\",\"COMPLETE\",\"--payload\",JSON.stringify({result:\"PASS\"})]))}catch(e){obs.commitCrash={error:String((e as Error).message)}}\nawait sqlite.execute(`DROP TRIGGER inj_commit`);\nobs.afterCommitCrash=await snap();\nobs.commitA=await dispatchBrain(payload([\"commit\",\"--agent\",\"A\",\"--task\",\"T1\",\"--expected-workstream-generation\",String(obs.claimA.workstream_generation),\"--state\",\"COMPLETE\",\"--payload\",JSON.stringify({result:\"PASS\"})]));\nconst good=await dispatchBrain(payload([\"verify-chain\"]));const realHead=good.computed_head;\nawait sqlite.execute({sql:`UPDATE ${P}epoch_meta SET event_head_hash='BROKEN' WHERE id=1`});\ntry{obs.staleParent=await dispatchBrain(reg(\"E\"))}catch(e){obs.staleParent={error:String((e as Error).message)}}\nobs.eAfterStale=await one(`SELECT id FROM ${P}agents WHERE id='E'`);\nawait sqlite.execute({sql:`UPDATE ${P}epoch_meta SET event_head_hash=? WHERE id=1`,args:[realHead]});\nobs.concurrentRegs=await Promise.all([dispatchBrain(reg(\"C\")),dispatchBrain(reg(\"D\"))]);\nobs.claimRace=await Promise.all([\n dispatchBrain(payload([\"claim\",\"--agent\",\"B\",\"--mode\",\"INTERACTIVE\",\"--lease-seconds\",\"900\"])),\n dispatchBrain(payload([\"claim\",\"--agent\",\"C\",\"--mode\",\"INTERACTIVE\",\"--lease-seconds\",\"900\"]))\n]);\nobs.finalChain=await dispatchBrain(payload([\"verify-chain\"]));\nobs.finalGraph=await dispatchBrain(payload([\"verify-claim-graph\"]));\nobs.final=await snap();\nconst same=(a:any,b:any)=>JSON.stringify(a)===JSON.stringify(b);\nconst pass=\n !!obs.regCrash.error&&obs.afterRegCrash.agents===0&&obs.afterRegCrash.events===0&&Number(obs.afterRegCrash.meta.generation)===100&&\n !!obs.claimCrash.error&&same(beforeClaim,obs.afterClaimCrash)&&\n !!obs.commitCrash.error&&same(beforeCommit,obs.afterCommitCrash)&&\n !!obs.staleParent.error&&!obs.eAfterStale&&\n obs.concurrentRegs.every((x:any)=>x.ok)&&\n obs.claimRace.filter((x:any)=>x.ok).length===1&&\n obs.finalChain.ok&&obs.finalGraph.ok;\nconst receipt={schema:\"BRAIN_CURRENT_KERNEL_ASYNCLOCAL_COMMAND_ATOMICITY_FALSIFICATION_V1\",classification:\"NONAUTHORITY_DISPOSABLE_TEST\",obs,pass,direct_sprites_calls:0,human_authority_approval:false};\nconsole.log(JSON.stringify(receipt,null,2));\n","createdAt",["D",1788781241361],"branchVersion","branchId","b4bcf7da-179f-4537-b488-7c6e79360504","id","fa09a4dc-4916-4efd-b9fe-ed60dbb551c7","brain-epoch3-atomic-repair-0907",["D",1788780453045],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","Disposable atomic Brain mutation falsification","imageUrl","6be0fc5c-1fef-4bd6-a1e1-67a3f8c0764e","pinnedFileId","pinPreview","pinMigrated","screenshotVersion","likeCount",0,"orgId","01a0715b-703f-741f-ab35-c85020e4a5e0","tursoName","fa09a4dc49164efdb9feed60dbb551c7","tursoHostname","fa09a4dc49164efdb9feed60dbb551c7-val-town.aws-us-east-2.turso.io","tursoMeasuredAt",["D",1789563628475],"pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_98":97,"_106":102},"org",{"_98":97,"_99":100,"_101":102,"_18":55,"_103":104,"_105":25},"branch",{"_13":87,"_32":88,"_43":42,"_89":44,"_90":-5,"_91":-5,"_92":-5,"_93":-5,"_94":-5,"_95":45,"_96":97},"isOwned",11,"main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","mosadek","handle","displayName","Mo Sadek","avatar","https://lh3.googleusercontent.com/a/ACg8ocL1eT_LHhKSg5px3nXIO6eez79aZXef466qXKh2gak-0iwrvw=s96-c","tier","free","canRestrictVals","profileImageUrl","branchName","","adoptOrgId",{"_43":44,"_32":45,"_38":212,"_47":-5,"_48":25,"_49":50,"_51":50,"_52":53,"_54":-5,"_18":55,"_56":-5,"_57":25,"_58":-5,"_59":-5,"_60":61,"_62":63,"_64":65,"_66":67,"_68":213,"_70":-5,"_71":72,"_73":72,"_74":75,"_76":75,"_77":75,"_78":72,"_79":72,"_80":214,"_82":215,"_84":216,"_86":25},"tree",[187,188,189,190,191,192],"files",[187,188,189,190,191,192],"counts",{"_177":61,"_178":151,"_179":61,"_180":181,"_182":183},"contents",[129,130,131,132,133,134],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},{"_43":171,"_32":172,"_30":173,"_138":-5,"_41":42,"_40":169,"_140":149,"_38":174,"_13":61,"_33":34,"_35":175,"_24":25,"_143":-5,"_27":176},{"_43":167,"_32":28,"_30":31,"_138":-5,"_41":42,"_40":14,"_140":25,"_38":168,"_13":169,"_33":34,"_35":37,"_24":25,"_143":-5,"_27":170},{"_43":160,"_32":161,"_30":162,"_138":-5,"_41":42,"_40":163,"_140":149,"_38":164,"_13":61,"_33":34,"_35":165,"_24":25,"_143":-5,"_27":166},{"_43":154,"_32":155,"_30":156,"_138":-5,"_41":42,"_40":151,"_140":149,"_38":157,"_13":61,"_33":34,"_35":158,"_24":25,"_143":-5,"_27":159},{"_43":145,"_32":146,"_30":147,"_138":-5,"_41":42,"_40":148,"_140":149,"_38":150,"_13":151,"_33":34,"_35":152,"_24":25,"_143":-5,"_27":153},{"_43":135,"_32":136,"_30":137,"_138":-5,"_41":42,"_40":139,"_140":25,"_38":141,"_13":61,"_33":34,"_35":142,"_24":25,"_143":-5,"_27":144},"e555f37e-b7ad-4e90-a93c-174e5fb67a1d","val_native_kernel_quarantine_candidate.ts","ec9e1de0-aab0-11f1-9b86-1607ee4eb77e","parentId",8,"latest",["D",1788781228544],"import { sqlite as rootSqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\nimport { blob } from \"https://esm.town/v/std/blob/main.ts\";\nimport { AsyncLocalStorage } from \"node:async_hooks\";\n\nconst txContext=new AsyncLocalStorage();\nconst sqlite:any={\n execute:(...args:any[])=>{const db=txContext.getStore()??rootSqlite;return db.execute(...args)},\n batch:async(queries:any[],mode?:any)=>{\n const tx=txContext.getStore();\n if(!tx)return await (rootSqlite as any).batch(queries,mode);\n const out:any[]=[];\n for(const q of queries)out.push(await tx.execute(q));\n return out;\n }\n};\nasync function withTransaction(mode:\"read\"|\"write\",fn:()=>Promise):Promise{\n if(txContext.getStore())return await fn();\n const tx:any=await (rootSqlite as any).transaction(mode);\n try{\n const out=await txContext.run(tx,fn);\n await tx.commit();\n return out;\n }catch(e){\n try{await tx.rollback()}catch{}\n throw e;\n }\n}\n\nconst SRC=\"svrec1864_\",P=\"brainvn_\";\nconst PREDECESSOR_HEAD=\"d88a49daefd5520d5612c1bee960bcf7f587fc5f734a8e568b749e9bd390c1db\";\nconst PREDECESSOR_EVENTS=1991;\nconst enc=new TextEncoder();\nconst NON_AGENT=new Set([\"human_authority_approval\"]);\nconst SUPPORTED=new Set([\"status\",\"verify-chain\",\"verify-claim-graph\",\"register-agent\",\"ensure-task\",\"claim\",\"renew-lease\",\"recover-stale\",\"commit\"]);\nconst READ_ONLY_COMMANDS=new Set([\"status\",\"verify-chain\",\"verify-claim-graph\"]);\nconst EMERGENCY_MUTATIONS_FROZEN=true;\n\nfunction now(){return new Date().toISOString().replace(\"Z\",\"+00:00\")}\nfunction canon(x:any):string{\n if(x===null||typeof x!==\"object\")return JSON.stringify(x);\n if(Array.isArray(x))return \"[\"+x.map(canon).join(\",\")+\"]\";\n return \"{\"+Object.keys(x).sort().map(k=>JSON.stringify(k)+\":\"+canon(x[k])).join(\",\")+\"}\";\n}\nasync function sha(s:string){const d=await crypto.subtle.digest(\"SHA-256\",enc.encode(s));return[...new Uint8Array(d)].map(x=>x.toString(16).padStart(2,\"0\")).join(\"\")}\nasync function one(sql:string,args:any[]=[]){const r:any=await sqlite.execute({sql,args});return r.rows?.[0]??null}\nfunction flags(args:any[],start:number){const m:any={};for(let i=start;i=args.length)throw new Error(\"BAD_FLAG_VECTOR\");m[args[i].slice(2)]=args[i+1]}return m}\nfunction parseJson(s:any,kind:string){try{return JSON.parse(String(s))}catch{throw new Error(\"BAD_JSON_\"+kind)}}\nfunction exactTop(q:any){return q&&typeof q===\"object\"&&!Array.isArray(q)&&Object.keys(q).sort().join(\",\")===\"args,timeout\"&&Array.isArray(q.args)&&q.args.length>0&&q.args.every((x:any)=>typeof x===\"string\")&&Number.isInteger(q.timeout)&&q.timeout>=1&&q.timeout<=120}\nfunction cleanCaps(x:any){if(!Array.isArray(x)||x.some(v=>typeof v!==\"string\"||!v))throw new Error(\"CAPABILITIES_MUST_BE_STRING_LIST\");return [...new Set(x)].sort()}\nfunction cleanWrites(x:any){if(!Array.isArray(x)||x.some(v=>typeof v!==\"string\"||!v.trim()))throw new Error(\"WRITE_RESOURCES_MUST_BE_STRING_LIST\");return [...new Set(x.map((v:string)=>v.trim()))].sort()}\n\nasync function cloneState(){\n const tables=[\"meta\",\"workstreams\",\"agents\",\"tasks\",\"claims\",\"claim_deps\",\"artifacts\",\"replicas\",\"task_context_history\",\"task_invariant_history\",\"replay_log\",\"anchor\",\"epoch_events\",\"epoch_meta\"];\n for(const t of tables){await sqlite.execute(`DROP TABLE IF EXISTS ${P}${t}`);await sqlite.execute(`CREATE TABLE ${P}${t} AS SELECT * FROM ${SRC}${t}`)}\n await sqlite.execute(`DROP TABLE IF EXISTS ${Q}`);\n await sqlite.execute(`CREATE TABLE ${Q}(\n id TEXT PRIMARY KEY,priority REAL NOT NULL,payload_json TEXT NOT NULL,state TEXT NOT NULL,\n lease_owner TEXT,lease_attempt_id TEXT,lease_expires_at TEXT,result_json TEXT,error_json TEXT,\n created_at TEXT NOT NULL,updated_at TEXT NOT NULL)`);\n}\n\nasync function meta(){return await one(`SELECT * FROM ${P}epoch_meta WHERE id=1`)}\nasync function generation(){return Number((await meta()).generation)}\nasync function appendEvent(ws:string,agent:any,task:any,type:string,payload:any){\n if(!txContext.getStore())throw new Error(\"EVENT_APPEND_REQUIRES_COMMAND_TRANSACTION\");\n const m:any=await meta(),prev=String(m.event_head_hash),g=Number(m.generation);\n const e={event_uuid:crypto.randomUUID(),ts:now(),workstream:ws,agent_id:agent??null,task_id:task??null,type,payload,prev_hash:prev};\n const h=await sha(canon(e));\n const ins:any=await sqlite.execute({sql:`INSERT INTO ${P}epoch_events(local_seq,event_uuid,ts,workstream,agent_id,task_id,type,payload_json,prev_hash,event_hash,transaction_generation)\n SELECT (SELECT COALESCE(MAX(local_seq),0)+1 FROM ${P}epoch_events),?,?,?,?,?,?,?,?,?,?\n RETURNING local_seq`,\n args:[e.event_uuid,e.ts,ws,e.agent_id,e.task_id,type,canon(payload),prev,h,g]});\n const rows=ins.rows||[];\n if(rows.length!==1)throw new Error(\"EVENT_INSERT_FAILED\");\n const upd:any=await sqlite.execute({sql:`UPDATE ${P}epoch_meta\n SET event_head_hash=?,new_event_count=new_event_count+1\n WHERE id=1 AND event_head_hash=? AND generation=?\n RETURNING new_event_count`,args:[h,prev,g]});\n if((upd.rows||[]).length!==1)throw new Error(\"EVENT_HEAD_CAS_FAILED\");\n return{seq:Number(rows[0].local_seq),event_hash:h};\n}\nasync function bump(){\n const r:any=await sqlite.execute(`UPDATE ${P}epoch_meta SET generation=generation+1 WHERE id=1 RETURNING generation`);\n if(!(r.rows||[]).length)throw new Error(\"GENERATION_BUMP_FAILED\");\n return Number(r.rows[0].generation);\n}\n\nasync function artifactBelongs(h:string,ws:string){\n const a:any=await one(`SELECT task_id,producer_agent FROM ${P}artifacts WHERE sha256=?`,[h]);if(!a)return false;\n if(a.task_id){const t:any=await one(`SELECT workstream FROM ${P}tasks WHERE id=?`,[a.task_id]);if(t&&String(t.workstream)===ws)return true}\n if(a.producer_agent){const ag:any=await one(`SELECT workstream FROM ${P}agents WHERE id=?`,[a.producer_agent]);if(ag&&String(ag.workstream)===ws)return true}\n return false;\n}\nasync function depsSatisfied(r:any){for(const d of parseJson(r.depends_json||\"[]\",\"DEPS\")){const x:any=await one(`SELECT state FROM ${P}tasks WHERE id=?`,[d]);if(!x||String(x.state)!==\"COMPLETE\")return false}return true}\nasync function guardsSatisfied(r:any){\n for(const g of parseJson(r.guards_json||\"[]\",\"GUARDS\")){\n if(g.type===\"task_complete\"){const x:any=await one(`SELECT workstream,state FROM ${P}tasks WHERE id=?`,[g.id]);if(!x||String(x.workstream)!==String(r.workstream)||String(x.state)!==\"COMPLETE\")return false}\n else if(g.type===\"claim_verified\"){const x:any=await one(`SELECT workstream,status FROM ${P}claims WHERE id=?`,[g.id]);if(!x||String(x.workstream)!==String(r.workstream)||String(x.status)!==\"VERIFIED\")return false}\n else if(g.type===\"artifact_present\"){if(!await artifactBelongs(String(g.sha256),String(r.workstream)))return false}\n else return false;\n }return true\n}\nasync function normalizeGuards(ws:string,x:any){\n if(!Array.isArray(x))throw new Error(\"GUARDS_MUST_BE_LIST\");const out:any[]=[],seen=new Set();\n for(const g of x){\n if(!g||typeof g!==\"object\"||Array.isArray(g))throw new Error(\"GUARD_MUST_BE_OBJECT\");let ng:any;\n if(g.type===\"task_complete\"){if(typeof g.id!==\"string\"||!g.id)throw new Error(\"BAD_TASK_GUARD\");const r:any=await one(`SELECT workstream,state FROM ${P}tasks WHERE id=?`,[g.id]);if(!r)throw new Error(\"UNKNOWN_GUARD_TASK\");if(String(r.workstream)!==ws)throw new Error(\"CROSS_WORKSTREAM_TASK_GUARD\");if([\"INVALID\",\"BLOCKED\"].includes(String(r.state)))throw new Error(\"TERMINAL_TASK_GUARD\");ng={type:\"task_complete\",id:g.id}}\n else if(g.type===\"claim_verified\"){if(typeof g.id!==\"string\"||!g.id)throw new Error(\"BAD_CLAIM_GUARD\");const r:any=await one(`SELECT workstream,status FROM ${P}claims WHERE id=?`,[g.id]);if(!r)throw new Error(\"UNKNOWN_GUARD_CLAIM\");if(String(r.workstream)!==ws)throw new Error(\"CROSS_WORKSTREAM_CLAIM_GUARD\");if(String(r.status)!==\"VERIFIED\")throw new Error(\"CLAIM_GUARD_NOT_VERIFIED\");ng={type:\"claim_verified\",id:g.id}}\n else if(g.type===\"artifact_present\"){const h=String(g.sha256||\"\").toLowerCase();if(!/^[0-9a-f]{64}$/.test(h))throw new Error(\"BAD_ARTIFACT_GUARD_SHA256\");ng={type:\"artifact_present\",sha256:h}}\n else throw new Error(\"UNKNOWN_GUARD_TYPE\");\n const k=canon(ng);if(!seen.has(k)){seen.add(k);out.push(ng)}\n }out.sort((a,b)=>canon(a).localeCompare(canon(b)));return out\n}\nasync function writeConflict(r:any){\n const writes=new Set(parseJson(r.writes_json||\"[]\",\"WRITES\"));if(!writes.size)return null;\n const q:any=await sqlite.execute(`SELECT id,workstream,lease_owner,writes_json FROM ${P}tasks WHERE state='LEASED'`);\n for(const o of q.rows||[]){const ow=new Set(parseJson(o.writes_json||\"[]\",\"WRITES\"));const overlap=[...writes].filter(x=>ow.has(x)).sort();if(overlap.length)return{task_id:o.id,workstream:o.workstream,lease_owner:o.lease_owner,resources:overlap}}\n return null\n}\nasync function bestReady(ws:string,caps:string[],agentId:string){\n const q:any=await sqlite.execute({sql:`SELECT * FROM ${P}tasks WHERE workstream=? AND state='READY' ORDER BY priority DESC,id`,args:[ws]});const C=new Set(caps);\n for(const r of q.rows||[]){\n if(!r.dedupe_key)continue;if(r.assigned_agent!==null&&String(r.assigned_agent)!==agentId)continue;\n const req=new Set(parseJson(r.requires_json||\"[]\",\"REQ\")),ctx=parseJson(r.context_manifest||\"{}\",\"CTX\");\n if(ctx.execution_allowed===false)continue;if([...req].some(x=>NON_AGENT.has(x)))continue;if([...req].some(x=>!C.has(x)))continue;\n if(!await depsSatisfied(r)||!await guardsSatisfied(r)||await writeConflict(r))continue;return r\n }return null\n}\n\nasync function quarantineRows(epoch:number){\n const exists:any=await one(`SELECT name FROM sqlite_master WHERE type='table' AND name=?`,[`${P}event_quarantine`]);\n if(!exists)return[];\n return (await sqlite.execute({sql:`SELECT * FROM ${P}event_quarantine WHERE epoch=? ORDER BY local_seq`,args:[epoch]})).rows||[];\n}\nasync function verifyChain(){\n const m:any=await meta(),es:any[]=(await sqlite.execute(`SELECT * FROM ${P}epoch_events ORDER BY local_seq`)).rows as any[];\n const qs:any[]=await quarantineRows(Number(m.epoch));\n const qmap=new Map(qs.map((q:any)=>[Number(q.local_seq),q]));\n const committedBySeq=new Map(es.map((e:any)=>[Number(e.local_seq),e]));\n const committedHashes=new Set(es.map((e:any)=>String(e.event_hash)));\n let prev=String(m.predecessor_head),expectedSeq=1,bad:any[]=[],structural_problems:any[]=[],verifiedQuarantines=0;\n for(const r of es){\n const seq=Number(r.local_seq);\n while(expectedSeqString(e.event_hash)===String(q.recovery_event_hash));\n if(!recovery||String(recovery.type)!==\"CONTROL_PLANE_FORK_RECOVERY_ANCHORED\")structural_problems.push({reason:\"QUARANTINE_RECOVERY_EVENT_MISSING\",local_seq:expectedSeq});\n else{\n const rp=parseJson(recovery.payload_json,\"RECOVERY_PAYLOAD\");\n if(String(rp.quarantine_manifest_sha256)!==String(q.manifest_sha256)||Number(rp.quarantined_local_seq)!==expectedSeq||String(rp.quarantined_event_hash)!==String(q.event_hash))structural_problems.push({reason:\"QUARANTINE_RECOVERY_BINDING_MISMATCH\",local_seq:expectedSeq});\n }\n verifiedQuarantines++;\n expectedSeq++;\n }\n if(seq!==expectedSeq){structural_problems.push({reason:\"LOCAL_SEQ_ORDER_INVALID\",expected:expectedSeq,actual:seq});expectedSeq=seq}\n const payload=parseJson(r.payload_json,\"EVENT_PAYLOAD\");\n const h=await sha(canon({event_uuid:r.event_uuid,ts:r.ts,workstream:r.workstream,agent_id:r.agent_id,task_id:r.task_id,type:r.type,payload,prev_hash:r.prev_hash}));\n if(String(r.prev_hash)!==prev||String(r.event_hash)!==h)bad.push({seq:r.local_seq});\n prev=String(r.event_hash);expectedSeq=seq+1;\n }\n for(const q of qs){if(Number(q.local_seq)>=expectedSeq)structural_problems.push({reason:\"QUARANTINE_NOT_A_COMMITTED_LOG_GAP\",local_seq:Number(q.local_seq)})}\n if(Number(m.new_event_count)!==es.length)structural_problems.push({reason:\"META_EVENT_COUNT_MISMATCH\",meta:Number(m.new_event_count),rows:es.length});\n const maxSeq=es.length?Number(es[es.length-1].local_seq):0;\n if(es.length+verifiedQuarantines!==maxSeq)structural_problems.push({reason:\"COMMITTED_PLUS_QUARANTINE_COUNT_MISMATCH\",committed:es.length,quarantined:verifiedQuarantines,max_local_seq:maxSeq});\n const storedHead=String(m.event_head_hash),headOk=prev===storedHead;\n if(!headOk)structural_problems.push({reason:\"STORED_HEAD_MISMATCH\",computed:prev,stored:storedHead});\n const predecessor_event_count=Number(m.predecessor_event_count);\n return{ok:bad.length===0&&structural_problems.length===0,classification:verifiedQuarantines?\"VERIFIED_RECOVERED_WITH_EXPLICIT_QUARANTINE\":\"CLEAN_APPEND_ONLY\",predecessor_event_count,new_events:es.length,quarantined_events:verifiedQuarantines,total_events:predecessor_event_count+es.length,computed_head:prev,stored_head:storedHead,generation:Number(m.generation),bad,structural_problems}\n}\nasync function verifyClaimGraph(){\n const claims:any[]=(await sqlite.execute(`SELECT * FROM ${P}claims ORDER BY id`)).rows as any[],deps:any[]=(await sqlite.execute(`SELECT * FROM ${P}claim_deps`)).rows as any[];const cm=new Map(claims.map(x=>[String(x.id),x])),problems:any[]=[];\n for(const d of deps){const p:any=cm.get(String(d.parent_claim)),c:any=cm.get(String(d.child_claim));if(!p||!c)problems.push({dep:d,reason:\"MISSING_CLAIM\"});else if(String(p.workstream)!==String(c.workstream))problems.push({dep:d,reason:\"CROSS_WORKSTREAM\"});else if([\"FALSIFIED\",\"STALE\"].includes(String(p.status))&&String(c.status)===\"VERIFIED\")problems.push({dep:d,reason:\"VERIFIED_CHILD_OF_INVALID_PARENT\"})}\n return{ok:problems.length===0,claims:claims.length,problems}\n}\nasync function status(){\n const m:any=await meta();const counts:any={};for(const t of [\"agents\",\"tasks\",\"claims\",\"artifacts\"])counts[t]=Number((await one(`SELECT COUNT(*) n FROM ${P}${t}`)).n);\n const states:any=(await sqlite.execute(`SELECT state,COUNT(*) n FROM ${P}tasks GROUP BY state ORDER BY state`)).rows;\n return{ok:true,classification:\"VAL_NATIVE_RECOVERY_EPOCH\",epoch:Number(m.epoch),generation:Number(m.generation),event_head_hash:String(m.event_head_hash),predecessor_generation:Number(m.predecessor_generation),predecessor_head:String(m.predecessor_head),new_event_count:Number(m.new_event_count),counts,task_states:states}\n}\n\nasync function register(args:string[]){\n if(args.length<2)throw new Error(\"REGISTER_ID_REQUIRED\");const id=args[1],f=flags(args,2),ws=String(f.workstream||\"\"),role=String(f.role||\"\"),type=String(f.type||\"\"),parent=f.parent??null,caps=cleanCaps(parseJson(f.capabilities||\"[]\",\"CAPS\"));\n if(!ws||!role||!type)throw new Error(\"REGISTER_FIELDS_REQUIRED\");if(!await one(`SELECT id FROM ${P}workstreams WHERE id=?`,[ws]))throw new Error(\"UNKNOWN_WORKSTREAM\");\n if(parent){if(String(parent)===id)throw new Error(\"AGENT_CANNOT_PARENT_SELF\");const pr:any=await one(`SELECT workstream FROM ${P}agents WHERE id=?`,[parent]);if(!pr)throw new Error(\"UNKNOWN_PARENT_AGENT\");if(String(pr.workstream)!==ws)throw new Error(\"CROSS_WORKSTREAM_PARENT\")}\n const ex:any=await one(`SELECT * FROM ${P}agents WHERE id=?`,[id]);if(ex){const same=String(ex.workstream)===ws&&String(ex.role)===role&&String(ex.type)===type&&(ex.parent_id??null)===(parent??null)&&String(ex.capabilities_json)===canon(caps);if(!same)throw new Error(\"AGENT_REJOIN_IDENTITY_MISMATCH\");await sqlite.execute({sql:`UPDATE ${P}agents SET last_seen=? WHERE id=?`,args:[now(),id]});return{ok:true,created:false,agent_id:id,generation:await generation()}}\n const g0=await generation();await sqlite.execute({sql:`INSERT INTO ${P}agents(id,parent_id,type,workstream,role,status,boot_generation,last_generation,last_seen,capabilities_json) VALUES(?,?,?,?,?,'READY',?,?,?,?)`,args:[id,parent,type,ws,role,g0,g0,now(),canon(caps)]});await appendEvent(ws,id,null,\"AGENT_REGISTERED\",{type,role,parent,boot_generation:g0,capabilities:caps});const ng=await bump();await sqlite.execute({sql:`UPDATE ${P}agents SET last_generation=? WHERE id=?`,args:[ng,id]});return{ok:true,created:true,agent_id:id,generation:ng}\n}\nasync function ensureTask(args:string[]){\n if(args.length<2)throw new Error(\"TASK_ID_REQUIRED\");const id=args[1],f=flags(args,2),ws=String(f.workstream||\"\"),dedupe=String(f[\"dedupe-key\"]||\"\");if(!ws||!dedupe)throw new Error(\"ENSURE_FIELDS_REQUIRED\");\n const deps=parseJson(f.depends||\"[]\",\"DEPS\"),ctx=parseJson(f.context||\"{}\",\"CTX\"),req=parseJson(f.requires||\"[]\",\"REQ\"),writes=cleanWrites(parseJson(f.writes||\"[]\",\"WRITES\")),guards=await normalizeGuards(ws,parseJson(f.guards||\"[]\",\"GUARDS\"));\n if(!Array.isArray(deps)||!ctx||Array.isArray(ctx)||!Array.isArray(req))throw new Error(\"BAD_JSON_SHAPE\");\n const existing:any=await one(`SELECT * FROM ${P}tasks WHERE workstream=? AND dedupe_key=? ORDER BY created_at DESC LIMIT 1`,[ws,dedupe]);if(existing)return{ok:true,created:false,task_id:existing.id,state:existing.state,lease_owner:existing.lease_owner,generation:await generation(),dedupe_key:dedupe};\n if(!await one(`SELECT id FROM ${P}workstreams WHERE id=?`,[ws]))throw new Error(\"UNKNOWN_WORKSTREAM\");\n for(const d of deps){const r:any=await one(`SELECT workstream,state FROM ${P}tasks WHERE id=?`,[d]);if(!r)throw new Error(\"UNKNOWN_DEP\");if(String(r.workstream)!==ws)throw new Error(\"CROSS_WORKSTREAM_DEP\");if([\"INVALID\",\"BLOCKED\"].includes(String(r.state)))throw new Error(\"TERMINAL_DEPENDENCY\")}\n const t=now(),priority=Number(f.priority);if(!Number.isFinite(priority))throw new Error(\"BAD_PRIORITY\");\n await sqlite.execute({sql:`INSERT INTO ${P}tasks(id,workstream,state,priority,depends_json,success_condition,decision_value,context_manifest,lease_owner,lease_mode,lease_generation,lease_expires_at,created_at,updated_at,result_event_id,requires_json,dedupe_key,assigned_agent,delegated_by,writes_json,guards_json) VALUES(?,?,'READY',?,?,?,?,?,NULL,NULL,NULL,NULL,?,?,NULL,?,?,NULL,NULL,?,?)`,args:[id,ws,priority,canon(deps),String(f.success||\"\"),String(f.value||\"\"),canon(ctx),t,t,canon(req),dedupe,canon(writes),canon(guards)]});\n await appendEvent(ws,f.agent??null,id,\"TASK_CREATED\",{priority,depends:deps,requires:req,writes,guards,dedupe_key:dedupe,success_condition:String(f.success||\"\"),decision_value:String(f.value||\"\")});const ng=await bump();await sqlite.execute({sql:`UPDATE ${P}workstreams SET head_generation=?,updated_at=? WHERE id=?`,args:[ng,now(),ws]});return{ok:true,created:true,task_id:id,state:\"READY\",generation:ng,dedupe_key:dedupe}\n}\nasync function claim(args:string[]){\n const f=flags(args,1),id=String(f.agent||\"\"),mode=String(f.mode||\"INTERACTIVE\"),secs=f[\"lease-seconds\"]===undefined?(mode===\"INTERACTIVE\"?1800:900):Number(f[\"lease-seconds\"]);if(!id)throw new Error(\"AGENT_REQUIRED\");if(![\"INTERACTIVE\",\"PROCESS\"].includes(mode)||secs<60||secs>7200)throw new Error(\"BAD_LEASE\");\n const ag:any=await one(`SELECT * FROM ${P}agents WHERE id=?`,[id]);if(!ag)throw new Error(\"UNKNOWN_AGENT\");const held:any=await one(`SELECT id,lease_expires_at FROM ${P}tasks WHERE state='LEASED' AND lease_owner=? ORDER BY updated_at DESC LIMIT 1`,[id]);const g0=await generation();\n if(held){if(held.lease_expires_at&&String(held.lease_expires_at)7200)throw new Error(\"BAD_RENEW\");\n const r:any=await one(`SELECT * FROM ${P}tasks WHERE id=?`,[task]);if(!r)throw new Error(\"UNKNOWN_TASK\");if(String(r.state)!==\"LEASED\"||String(r.lease_owner)!==agent)throw new Error(\"NOT_LEASE_OWNER\");if(r.lease_expires_at&&String(r.lease_expires_at)String(r.workstream)))].sort();for(const ws of wss)await sqlite.execute({sql:`UPDATE ${P}workstreams SET head_generation=?,updated_at=? WHERE id=?`,args:[g,now(),ws]})}return{ok:true,recovered,generation:g}\n}\nasync function commit(args:string[]){\n const f=flags(args,1),agent=String(f.agent||\"\"),taskId=String(f.task||\"\"),state=String(f.state||\"COMPLETE\");if(!agent||!taskId)throw new Error(\"COMMIT_FIELDS_REQUIRED\");if(state!==\"COMPLETE\")throw new Error(\"UNSUPPORTED_VAL_NATIVE_COMMIT_STATE\");\n const task:any=await one(`SELECT * FROM ${P}tasks WHERE id=?`,[taskId]),ag:any=await one(`SELECT * FROM ${P}agents WHERE id=?`,[agent]);if(!task||!ag)throw new Error(\"UNKNOWN_TASK_OR_AGENT\");if(String(task.workstream)!==String(ag.workstream))throw new Error(\"CROSS_WORKSTREAM_COMMIT\");if(String(task.lease_owner)!==agent)throw new Error(\"NOT_LEASE_OWNER\");if(task.lease_expires_at&&String(task.lease_expires_at)String(a.id).localeCompare(String(b.id))||String(a.state).localeCompare(String(b.state)))\n}\nasync function terminalGuardFailures(r:any){\n const out:any[]=[];for(const g of parseJson(r.guards_json||\"[]\",\"GUARDS\")){\n if(g.type===\"task_complete\"){const x:any=await one(`SELECT workstream,state FROM ${P}tasks WHERE id=?`,[g.id]);if(!x)out.push({type:g.type,id:g.id,state:\"MISSING\"});else if(String(x.workstream)!==String(r.workstream))out.push({type:g.type,id:g.id,state:\"CROSS_WORKSTREAM\"});else if([\"INVALID\",\"BLOCKED\"].includes(String(x.state)))out.push({type:g.type,id:g.id,state:String(x.state)})}\n else if(g.type===\"claim_verified\"){const x:any=await one(`SELECT workstream,status FROM ${P}claims WHERE id=?`,[g.id]);if(!x)out.push({type:g.type,id:g.id,status:\"MISSING\"});else if(String(x.workstream)!==String(r.workstream))out.push({type:g.type,id:g.id,status:\"CROSS_WORKSTREAM\"});else if([\"FALSIFIED\",\"STALE\"].includes(String(x.status)))out.push({type:g.type,id:g.id,status:String(x.status)})}\n }return out.sort((a,b)=>canon(a).localeCompare(canon(b)))\n}\nasync function propagateImpossible(ws:string,agent:any,rootCause:any){\n const changed:any[]=[];while(true){const rows:any[]=(await sqlite.execute({sql:`SELECT * FROM ${P}tasks WHERE workstream=? AND state='READY' ORDER BY id`,args:[ws]})).rows as any[];const round:any[]=[];\n for(const r of rows){const deps=await terminalDepFailures(r),guards=await terminalGuardFailures(r);if(!deps.length&&!guards.length)continue;const type=deps.length&&!guards.length?\"TASK_DEPENDENCY_BLOCKED\":\"TASK_CAUSALLY_BLOCKED\";let payload:any;\n if(type===\"TASK_DEPENDENCY_BLOCKED\")payload={blocking_dependencies:deps,root_terminal_task:(rootCause&&rootCause.task_id)||deps[0].id};\n else payload={blocking_dependencies:deps,blocking_guards:guards,root_cause:rootCause};\n const ev=await appendEvent(ws,agent,String(r.id),type,payload),eid=Number((await meta()).predecessor_event_count)+Number(ev.seq);\n const u:any=await sqlite.execute({sql:`UPDATE ${P}tasks SET state='BLOCKED',result_event_id=?,updated_at=?,lease_owner=NULL,lease_mode=NULL,lease_generation=NULL,lease_expires_at=NULL WHERE id=? AND state='READY' RETURNING id`,args:[eid,now(),r.id]});\n if((u.rows||[]).length){const item={task_id:r.id,event_id:eid,blocking_dependencies:deps,blocking_guards:guards};round.push(item);changed.push(item)}\n }if(!round.length)break;\n }return changed\n}\nasync function delegateTask(args:string[]){\n if(args.length<2)throw new Error(\"TASK_ID_REQUIRED\");const id=args[1],f=flags(args,2),ws=String(f.workstream||\"\"),parent=String(f[\"parent-agent\"]||\"\"),child=String(f[\"child-agent\"]||\"\"),dedupe=String(f[\"dedupe-key\"]||\"\");\n const deps=parseJson(f.depends||\"[]\",\"DEPS\"),ctx=parseJson(f.context||\"{}\",\"CTX\"),req=parseJson(f.requires||\"[]\",\"REQ\"),writes=cleanWrites(parseJson(f.writes||\"[]\",\"WRITES\")),guards=await normalizeGuards(ws,parseJson(f.guards||\"[]\",\"GUARDS\"));if(!ws||!parent||!child||!dedupe||!Array.isArray(deps)||!Array.isArray(req)||!ctx||Array.isArray(ctx))throw new Error(\"BAD_DELEGATE\");\n const p:any=await one(`SELECT * FROM ${P}agents WHERE id=?`,[parent]),c:any=await one(`SELECT * FROM ${P}agents WHERE id=?`,[child]);if(!p)throw new Error(\"UNKNOWN_PARENT_AGENT\");if(!c)throw new Error(\"UNKNOWN_CHILD_AGENT\");if(String(p.workstream)!==ws||String(c.workstream)!==ws)throw new Error(\"CROSS_WORKSTREAM_DELEGATION_FORBIDDEN\");if(String(c.parent_id)!==parent)throw new Error(\"NOT_DIRECT_CHILD\");\n const existing:any=await one(`SELECT * FROM ${P}tasks WHERE workstream=? AND dedupe_key=? ORDER BY created_at DESC LIMIT 1`,[ws,dedupe]);if(existing){if(String(existing.assigned_agent)!==child||String(existing.delegated_by)!==parent)throw new Error(\"DEDUPE_KEY_DELEGATION_MISMATCH\");return{ok:true,created:false,task_id:existing.id,state:existing.state,assigned_agent:existing.assigned_agent,delegated_by:existing.delegated_by,lease_owner:existing.lease_owner,generation:await generation(),dedupe_key:dedupe}}\n for(const d of deps){const r:any=await one(`SELECT workstream,state FROM ${P}tasks WHERE id=?`,[d]);if(!r)throw new Error(\"UNKNOWN_DEP\");if(String(r.workstream)!==ws)throw new Error(\"CROSS_WORKSTREAM_DEP_FORBIDDEN\");if([\"INVALID\",\"BLOCKED\"].includes(String(r.state)))throw new Error(\"TERMINAL_DEPENDENCY\")}\n const t=now(),priority=Number(f.priority??0);await sqlite.execute({sql:`INSERT INTO ${P}tasks(id,workstream,state,priority,depends_json,success_condition,decision_value,context_manifest,lease_owner,lease_mode,lease_generation,lease_expires_at,created_at,updated_at,result_event_id,requires_json,dedupe_key,assigned_agent,delegated_by,writes_json,guards_json) VALUES(?,?,'READY',?,?,?,?,?,NULL,NULL,NULL,NULL,?,?,NULL,?,?,?,?,?,?)`,args:[id,ws,priority,canon(deps),String(f.success||\"\"),String(f.value||\"\"),canon(ctx),t,t,canon(req),dedupe,child,parent,canon(writes),canon(guards)]});\n await appendEvent(ws,parent,id,\"TASK_DELEGATED\",{priority,depends:deps,requires:req,writes,guards,dedupe_key:dedupe,assigned_agent:child,delegated_by:parent,success_condition:String(f.success||\"\"),decision_value:String(f.value||\"\")});const ng=await bump();await sqlite.execute({sql:`UPDATE ${P}workstreams SET head_generation=?,updated_at=? WHERE id=?`,args:[ng,now(),ws]});return{ok:true,created:true,task_id:id,state:\"READY\",generation:ng,dedupe_key:dedupe,assigned_agent:child,delegated_by:parent}\n}\nasync function supersedeContext(args:string[]){\n const f=flags(args,1),taskId=String(f.task||\"\"),agent=String(f.agent||\"\"),expected=Number(f[\"expected-workstream-generation\"]),newCtx=parseJson(f[\"new-context\"],\"NEW_CONTEXT\"),evidence=parseJson(f.evidence||\"[]\",\"EVIDENCE\");if(!taskId||!agent||!Number.isInteger(expected)||!newCtx||Array.isArray(newCtx)||!Array.isArray(evidence))throw new Error(\"BAD_SUPERSEDE\");\n const task:any=await one(`SELECT * FROM ${P}tasks WHERE id=?`,[taskId]),ag:any=await one(`SELECT * FROM ${P}agents WHERE id=?`,[agent]);if(!task||!ag)throw new Error(\"UNKNOWN_TASK_OR_AGENT\");if(String(task.workstream)!==String(ag.workstream))throw new Error(\"CROSS_WORKSTREAM_TASK_CONTEXT_SUPERSESSION_FORBIDDEN\");if(String(task.state)!==\"READY\")throw new Error(\"TASK_CONTEXT_SUPERSESSION_REQUIRES_READY\");\n const actual=Number((await one(`SELECT head_generation FROM ${P}workstreams WHERE id=?`,[task.workstream])).head_generation);if(actual!==expected)return{ok:false,reason:\"STALE_WORKSTREAM_WRITE\",expected,actual,workstream:task.workstream};await validateEvidenceRefs(evidence);const oldCtx=parseJson(task.context_manifest||\"{}\",\"CTX\");if(canon(oldCtx)===canon(newCtx))return{ok:true,changed:false,task_id:taskId,generation:await generation(),workstream_generation:actual};\n const ver=Number((await one(`SELECT COALESCE(MAX(version),0)+1 n FROM ${P}task_context_history WHERE task_id=?`,[taskId])).n),ev=await appendEvent(String(task.workstream),agent,taskId,\"TASK_CONTEXT_SUPERSEDED\",{version:ver,reason:String(f.reason||\"\"),evidence,old_context:oldCtx,new_context:newCtx}),eid=Number((await meta()).predecessor_event_count)+Number(ev.seq),hid=Number((await one(`SELECT COALESCE(MAX(id),0)+1 n FROM ${P}task_context_history`)).n);\n await sqlite.execute({sql:`INSERT INTO ${P}task_context_history(id,task_id,version,old_context_json,new_context_json,reason,evidence_json,agent_id,event_id,created_at) VALUES(?,?,?,?,?,?,?,?,?,?)`,args:[hid,taskId,ver,canon(oldCtx),canon(newCtx),String(f.reason||\"\"),canon(evidence),agent,eid,now()]});await sqlite.execute({sql:`UPDATE ${P}tasks SET context_manifest=?,updated_at=? WHERE id=?`,args:[canon(newCtx),now(),taskId]});const ng=await bump();await sqlite.execute({sql:`UPDATE ${P}agents SET last_generation=?,last_seen=? WHERE id=?`,args:[ng,now(),agent]});await sqlite.execute({sql:`UPDATE ${P}workstreams SET head_generation=?,updated_at=? WHERE id=?`,args:[ng,now(),task.workstream]});return{ok:true,changed:true,task_id:taskId,version:ver,generation:ng,workstream_generation:ng,event_id:eid}\n}\nasync function ensureTaskInvariantRequiresColumns(){\n const r:any=await sqlite.execute(`PRAGMA table_info(${P}task_invariant_history)`),names=new Set((r.rows||[]).map((x:any)=>String(x.name)));\n if(!names.has(\"old_requires_json\"))await sqlite.execute(`ALTER TABLE ${P}task_invariant_history ADD COLUMN old_requires_json TEXT`);\n if(!names.has(\"new_requires_json\"))await sqlite.execute(`ALTER TABLE ${P}task_invariant_history ADD COLUMN new_requires_json TEXT`);\n}\nasync function migrateInvariants(args:string[]){\n const f=flags(args,1),taskId=String(f.task||\"\"),agent=String(f.agent||\"\"),expected=Number(f[\"expected-workstream-generation\"]),dedupe=String(f[\"dedupe-key\"]||\"\"),writes=cleanWrites(parseJson(f.writes||\"[]\",\"WRITES\")),evidence=parseJson(f.evidence||\"[]\",\"EVIDENCE\"),hasRequires=Object.prototype.hasOwnProperty.call(f,\"requires\"),requiresOverride=hasRequires?cleanCaps(parseJson(f.requires,\"REQUIRES\")):null;if(!taskId||!agent||!Number.isInteger(expected)||!dedupe||!Array.isArray(evidence))throw new Error(\"BAD_MIGRATE\");\n const task:any=await one(`SELECT * FROM ${P}tasks WHERE id=?`,[taskId]),ag:any=await one(`SELECT * FROM ${P}agents WHERE id=?`,[agent]);if(!task||!ag)throw new Error(\"UNKNOWN_TASK_OR_AGENT\");if(String(task.workstream)!==String(ag.workstream))throw new Error(\"CROSS_WORKSTREAM_TASK_MIGRATION_FORBIDDEN\");if(String(task.state)!==\"READY\")throw new Error(\"TASK_MIGRATION_REQUIRES_READY\");const guards=await normalizeGuards(String(task.workstream),parseJson(f.guards||\"[]\",\"GUARDS\"));\n const actual=Number((await one(`SELECT head_generation FROM ${P}workstreams WHERE id=?`,[task.workstream])).head_generation);if(actual!==expected)return{ok:false,reason:\"STALE_WORKSTREAM_WRITE\",expected,actual,workstream:task.workstream};await validateEvidenceRefs(evidence);const conflict:any=await one(`SELECT id,state FROM ${P}tasks WHERE workstream=? AND dedupe_key=? AND id<>? AND state IN ('READY','LEASED') LIMIT 1`,[task.workstream,dedupe,taskId]);if(conflict)throw new Error(\"OPEN_DEDUPE_CONFLICT\");\n const oldD=task.dedupe_key,oldW=String(task.writes_json||\"[]\"),oldG=String(task.guards_json||\"[]\"),oldR=String(task.requires_json||\"[]\"),oldReq=parseJson(oldR,\"OLDREQ\");if(!Array.isArray(oldReq))throw new Error(\"OLD_REQUIRES_NOT_LIST\");const newReq=hasRequires?requiresOverride:oldReq,newR=hasRequires?canon(newReq):oldR;if(String(oldD)===dedupe&&canon(parseJson(oldW,\"OLDW\"))===canon(writes)&&canon(parseJson(oldG,\"OLDG\"))===canon(guards)&&canon(oldReq)===canon(newReq))return{ok:true,changed:false,task_id:taskId,generation:await generation(),workstream_generation:actual};\n await ensureTaskInvariantRequiresColumns();const ver=Number((await one(`SELECT COALESCE(MAX(version),0)+1 n FROM ${P}task_invariant_history WHERE task_id=?`,[taskId])).n),ev=await appendEvent(String(task.workstream),agent,taskId,\"TASK_INVARIANTS_MIGRATED\",{version:ver,reason:String(f.reason||\"\"),evidence,old_dedupe_key:oldD,new_dedupe_key:dedupe,old_writes:parseJson(oldW,\"OLDW\"),new_writes:writes,old_guards:parseJson(oldG,\"OLDG\"),new_guards:guards,old_requires:oldReq,new_requires:newReq}),eid=Number((await meta()).predecessor_event_count)+Number(ev.seq),hid=Number((await one(`SELECT COALESCE(MAX(id),0)+1 n FROM ${P}task_invariant_history`)).n);\n await sqlite.execute({sql:`INSERT INTO ${P}task_invariant_history(id,task_id,version,old_dedupe_key,new_dedupe_key,old_writes_json,new_writes_json,old_guards_json,new_guards_json,old_requires_json,new_requires_json,reason,evidence_json,agent_id,event_id,created_at) VALUES(?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?)`,args:[hid,taskId,ver,oldD,dedupe,oldW,canon(writes),oldG,canon(guards),oldR,newR,String(f.reason||\"\"),canon(evidence),agent,eid,now()]});await sqlite.execute({sql:`UPDATE ${P}tasks SET dedupe_key=?,writes_json=?,guards_json=?,requires_json=?,updated_at=? WHERE id=?`,args:[dedupe,canon(writes),canon(guards),newR,now(),taskId]});const ng=await bump();await sqlite.execute({sql:`UPDATE ${P}agents SET last_generation=?,last_seen=? WHERE id=?`,args:[ng,now(),agent]});await sqlite.execute({sql:`UPDATE ${P}workstreams SET head_generation=?,updated_at=? WHERE id=?`,args:[ng,now(),task.workstream]});return{ok:true,changed:true,task_id:taskId,version:ver,generation:ng,workstream_generation:ng,event_id:eid,dedupe_key:dedupe,writes,guards,requires:newReq}\n}\nasync function reconcileCausal(args:string[]){\n const f=flags(args,1),ws=String(f.workstream||\"\"),agent=String(f.agent||\"\"),expected=Number(f[\"expected-workstream-generation\"]);if(!ws||!agent||!Number.isInteger(expected))throw new Error(\"BAD_RECONCILE\");const ag:any=await one(`SELECT workstream FROM ${P}agents WHERE id=?`,[agent]);if(!ag)throw new Error(\"UNKNOWN_AGENT\");if(String(ag.workstream)!==ws)throw new Error(\"CROSS_WORKSTREAM_RECONCILIATION_FORBIDDEN\");const actual=Number((await one(`SELECT head_generation FROM ${P}workstreams WHERE id=?`,[ws])).head_generation);if(actual!==expected)return{ok:false,reason:\"STALE_WORKSTREAM_WRITE\",expected,actual,workstream:ws};const changed=await propagateImpossible(ws,agent,{type:\"historical_reconcile\"});let ng=await generation();if(changed.length){ng=await bump();await sqlite.execute({sql:`UPDATE ${P}workstreams SET head_generation=?,updated_at=? WHERE id=?`,args:[ng,now(),ws]});await sqlite.execute({sql:`UPDATE ${P}agents SET last_generation=?,last_seen=? WHERE id=?`,args:[ng,now(),agent]})}return{ok:true,changed_count:changed.length,changed,generation:ng,workstream_generation:changed.length?ng:actual,workstream:ws}\n}\nasync function addClaimFull(args:string[]){\n if(args.length<2)throw new Error(\"CLAIM_ID_REQUIRED\");const id=args[1],f=flags(args,2),ws=String(f.workstream||\"\"),status0=String(f.status||\"VERIFIED\"),statement=parseJson(f.statement,\"STATEMENT\"),evidence=parseJson(f.evidence||\"[]\",\"EVIDENCE\"),deps=parseJson(f.depends||\"[]\",\"DEPS\");if(!ws||![\"VERIFIED\",\"CANDIDATE\",\"HYPOTHESIS\"].includes(status0)||!statement||Array.isArray(statement)||!Array.isArray(evidence)||!Array.isArray(deps))throw new Error(\"BAD_CLAIM\");if(!await one(`SELECT id FROM ${P}workstreams WHERE id=?`,[ws]))throw new Error(\"UNKNOWN_WORKSTREAM\");await validateEvidenceRefs(evidence);\n for(const d of deps){const r:any=await one(`SELECT workstream,status FROM ${P}claims WHERE id=?`,[d]);if(!r)throw new Error(\"UNKNOWN_CLAIM_DEP\");if(String(r.workstream)!==ws)throw new Error(\"CROSS_WORKSTREAM_CLAIM_DEP_FORBIDDEN\");if(String(r.status)!==\"VERIFIED\")throw new Error(\"NONVERIFIED_CLAIM_DEP\")}\n const raw=canon(statement),h=await sha(raw),g0=await generation(),t=now();if(await one(`SELECT id FROM ${P}claims WHERE id=?`,[id]))throw new Error(\"CLAIM_EXISTS\");await sqlite.execute({sql:`INSERT INTO ${P}claims(id,workstream,status,statement_json,statement_sha256,evidence_json,created_generation,invalidated_by,created_at,updated_at) VALUES(?,?,?,?,?,?,?,NULL,?,?)`,args:[id,ws,status0,raw,h,canon(evidence),g0,t,t]});for(const d of deps)await sqlite.execute({sql:`INSERT INTO ${P}claim_deps(parent_claim,child_claim) VALUES(?,?)`,args:[d,id]});await appendEvent(ws,f.agent??null,null,\"CLAIM_ADDED\",{claim_id:id,status:status0,statement_sha256:h,evidence,depends:deps});const ng=await bump();await sqlite.execute({sql:`UPDATE ${P}workstreams SET head_generation=?,updated_at=? WHERE id=?`,args:[ng,now(),ws]});return{ok:true,claim_id:id,statement_sha256:h,generation:ng}\n}\nasync function invalidateClaimFull(args:string[]){\n if(args.length<2)throw new Error(\"CLAIM_ID_REQUIRED\");const id=args[1],f=flags(args,2),reason=String(f.reason||\"\"),agent=f.agent??null;const root:any=await one(`SELECT workstream,status FROM ${P}claims WHERE id=?`,[id]);if(!root)throw new Error(\"UNKNOWN_CLAIM\");const todo=[id],seen=new Set(),changed:any[]=[];\n while(todo.length){const q=String(todo.pop());if(seen.has(q))continue;seen.add(q);const row:any=await one(`SELECT status FROM ${P}claims WHERE id=?`,[q]);if(row&&![\"FALSIFIED\",\"STALE\"].includes(String(row.status))){const ns=q===id?\"FALSIFIED\":\"STALE\";await sqlite.execute({sql:`UPDATE ${P}claims SET status=?,invalidated_by=?,updated_at=? WHERE id=?`,args:[ns,id,now(),q]});changed.push([q,ns])}const kids:any[]=(await sqlite.execute({sql:`SELECT child_claim FROM ${P}claim_deps WHERE parent_claim=?`,args:[q]})).rows as any[];for(const k of kids)todo.push(String(k.child_claim))}\n await appendEvent(String(root.workstream),agent,null,\"CLAIM_INVALIDATED\",{root_claim:id,reason,affected:changed});const propagated=await propagateImpossible(String(root.workstream),agent,{type:\"claim_invalidated\",claim_id:id,reason});const ng=await bump();await sqlite.execute({sql:`UPDATE ${P}workstreams SET head_generation=?,updated_at=? WHERE id=?`,args:[ng,now(),root.workstream]});return{ok:true,root_claim:id,affected:changed,generation:ng,propagated_blocked:propagated}\n}\nasync function commitFull(args:string[]){\n const f=flags(args,1),agent=String(f.agent||\"\"),taskId=String(f.task||\"\"),state=String(f.state||\"COMPLETE\");if(!agent||!taskId||![\"COMPLETE\",\"INVALID\",\"BLOCKED\"].includes(state))throw new Error(\"BAD_COMMIT\");const task:any=await one(`SELECT * FROM ${P}tasks WHERE id=?`,[taskId]),ag:any=await one(`SELECT * FROM ${P}agents WHERE id=?`,[agent]);if(!task||!ag)throw new Error(\"UNKNOWN_TASK_OR_AGENT\");if(String(task.workstream)!==String(ag.workstream))throw new Error(\"CROSS_WORKSTREAM_COMMIT_FORBIDDEN\");if(String(task.lease_owner)!==agent)throw new Error(\"NOT_LEASE_OWNER\");if(task.lease_expires_at&&String(task.lease_expires_at){\n if(cmd===\"status\")return await status();if(cmd===\"verify-chain\")return await verifyChain();if(cmd===\"verify-claim-graph\")return await verifyClaimGraph();if(cmd===\"register-agent\")return await register(q.args);if(cmd===\"ensure-task\")return await ensureTask(q.args);if(cmd===\"delegate-task\")return await delegateTask(q.args);if(cmd===\"claim\")return await claim(q.args);if(cmd===\"renew-lease\")return await renew(q.args);if(cmd===\"commit\")return await commitFull(q.args);if(cmd===\"checkpoint\")return await checkpointNative();if(cmd===\"add-claim\")return await addClaimFull(q.args);if(cmd===\"invalidate-claim\")return await invalidateClaimFull(q.args);if(cmd===\"supersede-task-context\")return await supersedeContext(q.args);if(cmd===\"migrate-task-invariants\")return await migrateInvariants(q.args);if(cmd===\"reconcile-causal-blocks\")return await reconcileCausal(q.args);if(cmd===\"recover-stale\"){if(q.args.length!==1)throw new Error(\"RECOVER_STALE_ARGS_INVALID\");return await recover()}throw new Error(\"UNREACHABLE\");\n };\n if(READ_ONLY_COMMANDS.has(cmd))return await withTransaction(\"read\",()=>invoke());\n if(EMERGENCY_MUTATIONS_FROZEN){\n const authority:any=await one(`SELECT epoch,writer,mode,source_generation,source_head FROM brain_control_plane_authority_v1 WHERE id=1`);\n return{ok:false,reason:\"VAL_NATIVE_MUTATIONS_EMERGENCY_FROZEN\",command:cmd,authority:authority??null};\n }\n return await withTransaction(\"write\",async()=>{\n const authority:any=await one(`SELECT epoch,writer,mode,source_generation,source_head FROM brain_control_plane_authority_v1 WHERE id=1`);\n if(!authority||String(authority.writer)!==\"val_native\"||String(authority.mode)!==\"ACTIVE\")return{ok:false,reason:\"VAL_NATIVE_MUTATIONS_AUTHORITY_FENCED\",command:cmd,authority:authority??null};\n return await invoke();\n });\n}\n\n\nasync function brainStatusSafe(){return await withTransaction(\"read\",()=>status())}\nasync function verifyBrainChainSafe(){return await withTransaction(\"read\",()=>verifyChain())}\nasync function verifyBrainClaimGraphSafe(){return await withTransaction(\"read\",()=>verifyClaimGraph())}\nasync function checkpointBrainNativeSafe(){return await dispatchFull(JSON.stringify({args:[\"checkpoint\"],timeout:120}))}\nasync function recoverBrainStaleSafe(){return await dispatchFull(JSON.stringify({args:[\"recover-stale\"],timeout:120}))}\nasync function registerBrainAgentSafe(args:string[]){return await dispatchFull(JSON.stringify({args,timeout:120}))}\nasync function claimBrainTaskSafe(args:string[]){return await dispatchFull(JSON.stringify({args,timeout:120}))}\nasync function brainGenerationSafe(){return await withTransaction(\"read\",()=>generation())}\n\nasync function statusRead(){return await withTransaction(\"read\",()=>status())}\nasync function verifyChainRead(){return await withTransaction(\"read\",()=>verifyChain())}\nasync function verifyClaimGraphRead(){return await withTransaction(\"read\",()=>verifyClaimGraph())}\nasync function authorizedDirectMutation(name:string,fn:()=>Promise){\n if(EMERGENCY_MUTATIONS_FROZEN){const a:any=await one(`SELECT epoch,writer,mode,source_generation,source_head FROM brain_control_plane_authority_v1 WHERE id=1`);return{ok:false,reason:\"VAL_NATIVE_MUTATIONS_EMERGENCY_FROZEN\",command:name,authority:a??null}}\n return await withTransaction(\"write\",async()=>{const a:any=await one(`SELECT epoch,writer,mode,source_generation,source_head FROM brain_control_plane_authority_v1 WHERE id=1`);if(!a||String(a.writer)!==\"val_native\"||String(a.mode)!==\"ACTIVE\")return{ok:false,reason:\"VAL_NATIVE_MUTATIONS_AUTHORITY_FENCED\",command:name,authority:a??null};return await fn()})\n}\nasync function checkpointDirect(){return await authorizedDirectMutation(\"checkpoint\",()=>checkpointNative())}\nasync function recoverDirect(){return await authorizedDirectMutation(\"recover-stale\",()=>recover())}\nasync function registerDirect(args:string[]){return await authorizedDirectMutation(\"register-agent\",()=>register(args))}\nasync function claimDirect(args:string[]){return await authorizedDirectMutation(\"claim\",()=>claim(args))}\n\nexport {\n dispatchFull as dispatchBrain,\n statusRead as brainStatus,\n verifyChainRead as verifyBrainChain,\n verifyClaimGraphRead as verifyBrainClaimGraph,\n checkpointDirect as checkpointBrainNative,\n recoverDirect as recoverBrainStale,\n registerDirect as registerBrainAgent,\n claimDirect as claimBrainTask,\n generation as brainGeneration\n};\n","label",[136],"04491b68-bbbb-4055-b979-2d9cec248f9e","val_native_kernel_atomic_candidate.ts","a3048b8e-aaaf-11f1-b6ce-1607ee4eb77e",4,true,["D",1788780741746],1,"import { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\nimport { blob } from \"https://esm.town/v/std/blob/main.ts\";\nimport { AsyncLocalStorage } from \"node:async_hooks\";\n\nconst SRC=\"svrec1864_\",P=\"brainvn_\";\nconst PREDECESSOR_HEAD=\"d88a49daefd5520d5612c1bee960bcf7f587fc5f734a8e568b749e9bd390c1db\";\nconst PREDECESSOR_EVENTS=1991;\nconst enc=new TextEncoder();\nconst dbScope=new AsyncLocalStorage();\nfunction DB(){return dbScope.getStore()??sqlite}\nconst NON_AGENT=new Set([\"human_authority_approval\"]);\nconst SUPPORTED=new Set([\"status\",\"verify-chain\",\"verify-claim-graph\",\"register-agent\",\"ensure-task\",\"claim\",\"renew-lease\",\"recover-stale\",\"commit\"]);\n\nfunction now(){return new Date().toISOString().replace(\"Z\",\"+00:00\")}\nfunction canon(x:any):string{\n if(x===null||typeof x!==\"object\")return JSON.stringify(x);\n if(Array.isArray(x))return \"[\"+x.map(canon).join(\",\")+\"]\";\n return \"{\"+Object.keys(x).sort().map(k=>JSON.stringify(k)+\":\"+canon(x[k])).join(\",\")+\"}\";\n}\nasync function sha(s:string){const d=await crypto.subtle.digest(\"SHA-256\",enc.encode(s));return[...new Uint8Array(d)].map(x=>x.toString(16).padStart(2,\"0\")).join(\"\")}\nasync function one(sql:string,args:any[]=[]){const r:any=await DB().execute({sql,args});return r.rows?.[0]??null}\nfunction flags(args:any[],start:number){const m:any={};for(let i=start;i=args.length)throw new Error(\"BAD_FLAG_VECTOR\");m[args[i].slice(2)]=args[i+1]}return m}\nfunction parseJson(s:any,kind:string){try{return JSON.parse(String(s))}catch{throw new Error(\"BAD_JSON_\"+kind)}}\nfunction exactTop(q:any){return q&&typeof q===\"object\"&&!Array.isArray(q)&&Object.keys(q).sort().join(\",\")===\"args,timeout\"&&Array.isArray(q.args)&&q.args.length>0&&q.args.every((x:any)=>typeof x===\"string\")&&Number.isInteger(q.timeout)&&q.timeout>=1&&q.timeout<=120}\nfunction cleanCaps(x:any){if(!Array.isArray(x)||x.some(v=>typeof v!==\"string\"||!v))throw new Error(\"CAPABILITIES_MUST_BE_STRING_LIST\");return [...new Set(x)].sort()}\nfunction cleanWrites(x:any){if(!Array.isArray(x)||x.some(v=>typeof v!==\"string\"||!v.trim()))throw new Error(\"WRITE_RESOURCES_MUST_BE_STRING_LIST\");return [...new Set(x.map((v:string)=>v.trim()))].sort()}\n\nasync function cloneState(){\n const tables=[\"meta\",\"workstreams\",\"agents\",\"tasks\",\"claims\",\"claim_deps\",\"artifacts\",\"replicas\",\"task_context_history\",\"task_invariant_history\",\"replay_log\",\"anchor\",\"epoch_events\",\"epoch_meta\"];\n for(const t of tables){await DB().execute(`DROP TABLE IF EXISTS ${P}${t}`);await DB().execute(`CREATE TABLE ${P}${t} AS SELECT * FROM ${SRC}${t}`)}\n await DB().execute(`DROP TABLE IF EXISTS ${Q}`);\n await DB().execute(`CREATE TABLE ${Q}(\n id TEXT PRIMARY KEY,priority REAL NOT NULL,payload_json TEXT NOT NULL,state TEXT NOT NULL,\n lease_owner TEXT,lease_attempt_id TEXT,lease_expires_at TEXT,result_json TEXT,error_json TEXT,\n created_at TEXT NOT NULL,updated_at TEXT NOT NULL)`);\n}\n\nasync function meta(){return await one(`SELECT * FROM ${P}epoch_meta WHERE id=1`)}\nasync function generation(){return Number((await meta()).generation)}\nasync function appendEvent(ws:string,agent:any,task:any,type:string,payload:any){\n const m:any=await meta(),g=Number(m.generation);\n const tail:any=await one(`SELECT event_hash FROM ${P}epoch_events ORDER BY local_seq DESC LIMIT 1`);\n const prev=tail?String(tail.event_hash):String(m.predecessor_head);\n if(prev!==String(m.event_head_hash))throw new Error(\"EVENT_HEAD_TAIL_MISMATCH\");\n const seq=Number((await one(`SELECT COALESCE(MAX(local_seq),0)+1 n FROM ${P}epoch_events`)).n);\n const e={event_uuid:crypto.randomUUID(),ts:now(),workstream:ws,agent_id:agent??null,task_id:task??null,type,payload,prev_hash:prev};\n const h=await sha(canon(e));\n await DB().execute({sql:`INSERT INTO ${P}epoch_events(local_seq,event_uuid,ts,workstream,agent_id,task_id,type,payload_json,prev_hash,event_hash,transaction_generation)\n VALUES(?,?,?,?,?,?,?,?,?,?,?)`,args:[seq,e.event_uuid,e.ts,ws,e.agent_id,e.task_id,type,canon(payload),prev,h,g]});\n const u:any=await DB().execute({sql:`UPDATE ${P}epoch_meta SET event_head_hash=?,new_event_count=new_event_count+1 WHERE id=1 AND event_head_hash=? AND generation=? RETURNING id`,args:[h,prev,g]});\n if((u.rows||[]).length!==1)throw new Error(\"EVENT_HEAD_CAS_LOST\");\n return{seq,event_hash:h};\n}\nasync function bump(){\n const r:any=await DB().execute(`UPDATE ${P}epoch_meta SET generation=generation+1 WHERE id=1 RETURNING generation`);\n if(!(r.rows||[]).length)throw new Error(\"GENERATION_BUMP_FAILED\");\n return Number(r.rows[0].generation);\n}\n\nasync function artifactBelongs(h:string,ws:string){\n const a:any=await one(`SELECT task_id,producer_agent FROM ${P}artifacts WHERE sha256=?`,[h]);if(!a)return false;\n if(a.task_id){const t:any=await one(`SELECT workstream FROM ${P}tasks WHERE id=?`,[a.task_id]);if(t&&String(t.workstream)===ws)return true}\n if(a.producer_agent){const ag:any=await one(`SELECT workstream FROM ${P}agents WHERE id=?`,[a.producer_agent]);if(ag&&String(ag.workstream)===ws)return true}\n return false;\n}\nasync function depsSatisfied(r:any){for(const d of parseJson(r.depends_json||\"[]\",\"DEPS\")){const x:any=await one(`SELECT state FROM ${P}tasks WHERE id=?`,[d]);if(!x||String(x.state)!==\"COMPLETE\")return false}return true}\nasync function guardsSatisfied(r:any){\n for(const g of parseJson(r.guards_json||\"[]\",\"GUARDS\")){\n if(g.type===\"task_complete\"){const x:any=await one(`SELECT workstream,state FROM ${P}tasks WHERE id=?`,[g.id]);if(!x||String(x.workstream)!==String(r.workstream)||String(x.state)!==\"COMPLETE\")return false}\n else if(g.type===\"claim_verified\"){const x:any=await one(`SELECT workstream,status FROM ${P}claims WHERE id=?`,[g.id]);if(!x||String(x.workstream)!==String(r.workstream)||String(x.status)!==\"VERIFIED\")return false}\n else if(g.type===\"artifact_present\"){if(!await artifactBelongs(String(g.sha256),String(r.workstream)))return false}\n else return false;\n }return true\n}\nasync function normalizeGuards(ws:string,x:any){\n if(!Array.isArray(x))throw new Error(\"GUARDS_MUST_BE_LIST\");const out:any[]=[],seen=new Set();\n for(const g of x){\n if(!g||typeof g!==\"object\"||Array.isArray(g))throw new Error(\"GUARD_MUST_BE_OBJECT\");let ng:any;\n if(g.type===\"task_complete\"){if(typeof g.id!==\"string\"||!g.id)throw new Error(\"BAD_TASK_GUARD\");const r:any=await one(`SELECT workstream,state FROM ${P}tasks WHERE id=?`,[g.id]);if(!r)throw new Error(\"UNKNOWN_GUARD_TASK\");if(String(r.workstream)!==ws)throw new Error(\"CROSS_WORKSTREAM_TASK_GUARD\");if([\"INVALID\",\"BLOCKED\"].includes(String(r.state)))throw new Error(\"TERMINAL_TASK_GUARD\");ng={type:\"task_complete\",id:g.id}}\n else if(g.type===\"claim_verified\"){if(typeof g.id!==\"string\"||!g.id)throw new Error(\"BAD_CLAIM_GUARD\");const r:any=await one(`SELECT workstream,status FROM ${P}claims WHERE id=?`,[g.id]);if(!r)throw new Error(\"UNKNOWN_GUARD_CLAIM\");if(String(r.workstream)!==ws)throw new Error(\"CROSS_WORKSTREAM_CLAIM_GUARD\");if(String(r.status)!==\"VERIFIED\")throw new Error(\"CLAIM_GUARD_NOT_VERIFIED\");ng={type:\"claim_verified\",id:g.id}}\n else if(g.type===\"artifact_present\"){const h=String(g.sha256||\"\").toLowerCase();if(!/^[0-9a-f]{64}$/.test(h))throw new Error(\"BAD_ARTIFACT_GUARD_SHA256\");ng={type:\"artifact_present\",sha256:h}}\n else throw new Error(\"UNKNOWN_GUARD_TYPE\");\n const k=canon(ng);if(!seen.has(k)){seen.add(k);out.push(ng)}\n }out.sort((a,b)=>canon(a).localeCompare(canon(b)));return out\n}\nasync function writeConflict(r:any){\n const writes=new Set(parseJson(r.writes_json||\"[]\",\"WRITES\"));if(!writes.size)return null;\n const q:any=await DB().execute(`SELECT id,workstream,lease_owner,writes_json FROM ${P}tasks WHERE state='LEASED'`);\n for(const o of q.rows||[]){const ow=new Set(parseJson(o.writes_json||\"[]\",\"WRITES\"));const overlap=[...writes].filter(x=>ow.has(x)).sort();if(overlap.length)return{task_id:o.id,workstream:o.workstream,lease_owner:o.lease_owner,resources:overlap}}\n return null\n}\nasync function bestReady(ws:string,caps:string[],agentId:string){\n const q:any=await DB().execute({sql:`SELECT * FROM ${P}tasks WHERE workstream=? AND state='READY' ORDER BY priority DESC,id`,args:[ws]});const C=new Set(caps);\n for(const r of q.rows||[]){\n if(!r.dedupe_key)continue;if(r.assigned_agent!==null&&String(r.assigned_agent)!==agentId)continue;\n const req=new Set(parseJson(r.requires_json||\"[]\",\"REQ\")),ctx=parseJson(r.context_manifest||\"{}\",\"CTX\");\n if(ctx.execution_allowed===false)continue;if([...req].some(x=>NON_AGENT.has(x)))continue;if([...req].some(x=>!C.has(x)))continue;\n if(!await depsSatisfied(r)||!await guardsSatisfied(r)||await writeConflict(r))continue;return r\n }return null\n}\n\nasync function verifyChain(){\n const m:any=await meta(),es:any[]=(await DB().execute(`SELECT * FROM ${P}epoch_events ORDER BY local_seq`)).rows as any[];\n let prev=String(m.predecessor_head),bad:any[]=[];\n for(const r of es){const payload=parseJson(r.payload_json,\"EVENT_PAYLOAD\");const h=await sha(canon({event_uuid:r.event_uuid,ts:r.ts,workstream:r.workstream,agent_id:r.agent_id,task_id:r.task_id,type:r.type,payload,prev_hash:r.prev_hash}));if(String(r.prev_hash)!==prev||String(r.event_hash)!==h)bad.push({seq:r.local_seq});prev=String(r.event_hash)}\n const predecessor_event_count=Number(m.predecessor_event_count);\n return{ok:bad.length===0&&prev===String(m.event_head_hash)&&es.length===Number(m.new_event_count),predecessor_event_count,new_events:es.length,total_events:predecessor_event_count+es.length,computed_head:prev,stored_head:String(m.event_head_hash),generation:Number(m.generation),bad}\n}\nasync function verifyClaimGraph(){\n const claims:any[]=(await DB().execute(`SELECT * FROM ${P}claims ORDER BY id`)).rows as any[],deps:any[]=(await DB().execute(`SELECT * FROM ${P}claim_deps`)).rows as any[];const cm=new Map(claims.map(x=>[String(x.id),x])),problems:any[]=[];\n for(const d of deps){const p:any=cm.get(String(d.parent_claim)),c:any=cm.get(String(d.child_claim));if(!p||!c)problems.push({dep:d,reason:\"MISSING_CLAIM\"});else if(String(p.workstream)!==String(c.workstream))problems.push({dep:d,reason:\"CROSS_WORKSTREAM\"});else if([\"FALSIFIED\",\"STALE\"].includes(String(p.status))&&String(c.status)===\"VERIFIED\")problems.push({dep:d,reason:\"VERIFIED_CHILD_OF_INVALID_PARENT\"})}\n return{ok:problems.length===0,claims:claims.length,problems}\n}\nasync function status(){\n const m:any=await meta();const counts:any={};for(const t of [\"agents\",\"tasks\",\"claims\",\"artifacts\"])counts[t]=Number((await one(`SELECT COUNT(*) n FROM ${P}${t}`)).n);\n const states:any=(await DB().execute(`SELECT state,COUNT(*) n FROM ${P}tasks GROUP BY state ORDER BY state`)).rows;\n return{ok:true,classification:\"VAL_NATIVE_RECOVERY_EPOCH\",epoch:Number(m.epoch),generation:Number(m.generation),event_head_hash:String(m.event_head_hash),predecessor_generation:Number(m.predecessor_generation),predecessor_head:String(m.predecessor_head),new_event_count:Number(m.new_event_count),counts,task_states:states}\n}\n\nasync function register(args:string[]){\n if(args.length<2)throw new Error(\"REGISTER_ID_REQUIRED\");const id=args[1],f=flags(args,2),ws=String(f.workstream||\"\"),role=String(f.role||\"\"),type=String(f.type||\"\"),parent=f.parent??null,caps=cleanCaps(parseJson(f.capabilities||\"[]\",\"CAPS\"));\n if(!ws||!role||!type)throw new Error(\"REGISTER_FIELDS_REQUIRED\");if(!await one(`SELECT id FROM ${P}workstreams WHERE id=?`,[ws]))throw new Error(\"UNKNOWN_WORKSTREAM\");\n if(parent){if(String(parent)===id)throw new Error(\"AGENT_CANNOT_PARENT_SELF\");const pr:any=await one(`SELECT workstream FROM ${P}agents WHERE id=?`,[parent]);if(!pr)throw new Error(\"UNKNOWN_PARENT_AGENT\");if(String(pr.workstream)!==ws)throw new Error(\"CROSS_WORKSTREAM_PARENT\")}\n const ex:any=await one(`SELECT * FROM ${P}agents WHERE id=?`,[id]);if(ex){const same=String(ex.workstream)===ws&&String(ex.role)===role&&String(ex.type)===type&&(ex.parent_id??null)===(parent??null)&&String(ex.capabilities_json)===canon(caps);if(!same)throw new Error(\"AGENT_REJOIN_IDENTITY_MISMATCH\");await DB().execute({sql:`UPDATE ${P}agents SET last_seen=? WHERE id=?`,args:[now(),id]});return{ok:true,created:false,agent_id:id,generation:await generation()}}\n const g0=await generation();await DB().execute({sql:`INSERT INTO ${P}agents(id,parent_id,type,workstream,role,status,boot_generation,last_generation,last_seen,capabilities_json) VALUES(?,?,?,?,?,'READY',?,?,?,?)`,args:[id,parent,type,ws,role,g0,g0,now(),canon(caps)]});await appendEvent(ws,id,null,\"AGENT_REGISTERED\",{type,role,parent,boot_generation:g0,capabilities:caps});const ng=await bump();await DB().execute({sql:`UPDATE ${P}agents SET last_generation=? WHERE id=?`,args:[ng,id]});return{ok:true,created:true,agent_id:id,generation:ng}\n}\nasync function ensureTask(args:string[]){\n if(args.length<2)throw new Error(\"TASK_ID_REQUIRED\");const id=args[1],f=flags(args,2),ws=String(f.workstream||\"\"),dedupe=String(f[\"dedupe-key\"]||\"\");if(!ws||!dedupe)throw new Error(\"ENSURE_FIELDS_REQUIRED\");\n const deps=parseJson(f.depends||\"[]\",\"DEPS\"),ctx=parseJson(f.context||\"{}\",\"CTX\"),req=parseJson(f.requires||\"[]\",\"REQ\"),writes=cleanWrites(parseJson(f.writes||\"[]\",\"WRITES\")),guards=await normalizeGuards(ws,parseJson(f.guards||\"[]\",\"GUARDS\"));\n if(!Array.isArray(deps)||!ctx||Array.isArray(ctx)||!Array.isArray(req))throw new Error(\"BAD_JSON_SHAPE\");\n const existing:any=await one(`SELECT * FROM ${P}tasks WHERE workstream=? AND dedupe_key=? ORDER BY created_at DESC LIMIT 1`,[ws,dedupe]);if(existing)return{ok:true,created:false,task_id:existing.id,state:existing.state,lease_owner:existing.lease_owner,generation:await generation(),dedupe_key:dedupe};\n if(!await one(`SELECT id FROM ${P}workstreams WHERE id=?`,[ws]))throw new Error(\"UNKNOWN_WORKSTREAM\");\n for(const d of deps){const r:any=await one(`SELECT workstream,state FROM ${P}tasks WHERE id=?`,[d]);if(!r)throw new Error(\"UNKNOWN_DEP\");if(String(r.workstream)!==ws)throw new Error(\"CROSS_WORKSTREAM_DEP\");if([\"INVALID\",\"BLOCKED\"].includes(String(r.state)))throw new Error(\"TERMINAL_DEPENDENCY\")}\n const t=now(),priority=Number(f.priority);if(!Number.isFinite(priority))throw new Error(\"BAD_PRIORITY\");\n await DB().execute({sql:`INSERT INTO ${P}tasks(id,workstream,state,priority,depends_json,success_condition,decision_value,context_manifest,lease_owner,lease_mode,lease_generation,lease_expires_at,created_at,updated_at,result_event_id,requires_json,dedupe_key,assigned_agent,delegated_by,writes_json,guards_json) VALUES(?,?,'READY',?,?,?,?,?,NULL,NULL,NULL,NULL,?,?,NULL,?,?,NULL,NULL,?,?)`,args:[id,ws,priority,canon(deps),String(f.success||\"\"),String(f.value||\"\"),canon(ctx),t,t,canon(req),dedupe,canon(writes),canon(guards)]});\n await appendEvent(ws,f.agent??null,id,\"TASK_CREATED\",{priority,depends:deps,requires:req,writes,guards,dedupe_key:dedupe,success_condition:String(f.success||\"\"),decision_value:String(f.value||\"\")});const ng=await bump();await DB().execute({sql:`UPDATE ${P}workstreams SET head_generation=?,updated_at=? WHERE id=?`,args:[ng,now(),ws]});return{ok:true,created:true,task_id:id,state:\"READY\",generation:ng,dedupe_key:dedupe}\n}\nasync function claim(args:string[]){\n const f=flags(args,1),id=String(f.agent||\"\"),mode=String(f.mode||\"INTERACTIVE\"),secs=f[\"lease-seconds\"]===undefined?(mode===\"INTERACTIVE\"?1800:900):Number(f[\"lease-seconds\"]);if(!id)throw new Error(\"AGENT_REQUIRED\");if(![\"INTERACTIVE\",\"PROCESS\"].includes(mode)||secs<60||secs>7200)throw new Error(\"BAD_LEASE\");\n const ag:any=await one(`SELECT * FROM ${P}agents WHERE id=?`,[id]);if(!ag)throw new Error(\"UNKNOWN_AGENT\");const held:any=await one(`SELECT id,lease_expires_at FROM ${P}tasks WHERE state='LEASED' AND lease_owner=? ORDER BY updated_at DESC LIMIT 1`,[id]);const g0=await generation();\n if(held){if(held.lease_expires_at&&String(held.lease_expires_at)7200)throw new Error(\"BAD_RENEW\");\n const r:any=await one(`SELECT * FROM ${P}tasks WHERE id=?`,[task]);if(!r)throw new Error(\"UNKNOWN_TASK\");if(String(r.state)!==\"LEASED\"||String(r.lease_owner)!==agent)throw new Error(\"NOT_LEASE_OWNER\");if(r.lease_expires_at&&String(r.lease_expires_at)String(r.workstream)))].sort();for(const ws of wss)await DB().execute({sql:`UPDATE ${P}workstreams SET head_generation=?,updated_at=? WHERE id=?`,args:[g,now(),ws]})}return{ok:true,recovered,generation:g}\n}\nasync function commit(args:string[]){\n const f=flags(args,1),agent=String(f.agent||\"\"),taskId=String(f.task||\"\"),state=String(f.state||\"COMPLETE\");if(!agent||!taskId)throw new Error(\"COMMIT_FIELDS_REQUIRED\");if(state!==\"COMPLETE\")throw new Error(\"UNSUPPORTED_VAL_NATIVE_COMMIT_STATE\");\n const task:any=await one(`SELECT * FROM ${P}tasks WHERE id=?`,[taskId]),ag:any=await one(`SELECT * FROM ${P}agents WHERE id=?`,[agent]);if(!task||!ag)throw new Error(\"UNKNOWN_TASK_OR_AGENT\");if(String(task.workstream)!==String(ag.workstream))throw new Error(\"CROSS_WORKSTREAM_COMMIT\");if(String(task.lease_owner)!==agent)throw new Error(\"NOT_LEASE_OWNER\");if(task.lease_expires_at&&String(task.lease_expires_at)String(a.id).localeCompare(String(b.id))||String(a.state).localeCompare(String(b.state)))\n}\nasync function terminalGuardFailures(r:any){\n const out:any[]=[];for(const g of parseJson(r.guards_json||\"[]\",\"GUARDS\")){\n if(g.type===\"task_complete\"){const x:any=await one(`SELECT workstream,state FROM ${P}tasks WHERE id=?`,[g.id]);if(!x)out.push({type:g.type,id:g.id,state:\"MISSING\"});else if(String(x.workstream)!==String(r.workstream))out.push({type:g.type,id:g.id,state:\"CROSS_WORKSTREAM\"});else if([\"INVALID\",\"BLOCKED\"].includes(String(x.state)))out.push({type:g.type,id:g.id,state:String(x.state)})}\n else if(g.type===\"claim_verified\"){const x:any=await one(`SELECT workstream,status FROM ${P}claims WHERE id=?`,[g.id]);if(!x)out.push({type:g.type,id:g.id,status:\"MISSING\"});else if(String(x.workstream)!==String(r.workstream))out.push({type:g.type,id:g.id,status:\"CROSS_WORKSTREAM\"});else if([\"FALSIFIED\",\"STALE\"].includes(String(x.status)))out.push({type:g.type,id:g.id,status:String(x.status)})}\n }return out.sort((a,b)=>canon(a).localeCompare(canon(b)))\n}\nasync function propagateImpossible(ws:string,agent:any,rootCause:any){\n const changed:any[]=[];while(true){const rows:any[]=(await DB().execute({sql:`SELECT * FROM ${P}tasks WHERE workstream=? AND state='READY' ORDER BY id`,args:[ws]})).rows as any[];const round:any[]=[];\n for(const r of rows){const deps=await terminalDepFailures(r),guards=await terminalGuardFailures(r);if(!deps.length&&!guards.length)continue;const type=deps.length&&!guards.length?\"TASK_DEPENDENCY_BLOCKED\":\"TASK_CAUSALLY_BLOCKED\";let payload:any;\n if(type===\"TASK_DEPENDENCY_BLOCKED\")payload={blocking_dependencies:deps,root_terminal_task:(rootCause&&rootCause.task_id)||deps[0].id};\n else payload={blocking_dependencies:deps,blocking_guards:guards,root_cause:rootCause};\n const ev=await appendEvent(ws,agent,String(r.id),type,payload),eid=Number((await meta()).predecessor_event_count)+Number(ev.seq);\n const u:any=await DB().execute({sql:`UPDATE ${P}tasks SET state='BLOCKED',result_event_id=?,updated_at=?,lease_owner=NULL,lease_mode=NULL,lease_generation=NULL,lease_expires_at=NULL WHERE id=? AND state='READY' RETURNING id`,args:[eid,now(),r.id]});\n if((u.rows||[]).length){const item={task_id:r.id,event_id:eid,blocking_dependencies:deps,blocking_guards:guards};round.push(item);changed.push(item)}\n }if(!round.length)break;\n }return changed\n}\nasync function delegateTask(args:string[]){\n if(args.length<2)throw new Error(\"TASK_ID_REQUIRED\");const id=args[1],f=flags(args,2),ws=String(f.workstream||\"\"),parent=String(f[\"parent-agent\"]||\"\"),child=String(f[\"child-agent\"]||\"\"),dedupe=String(f[\"dedupe-key\"]||\"\");\n const deps=parseJson(f.depends||\"[]\",\"DEPS\"),ctx=parseJson(f.context||\"{}\",\"CTX\"),req=parseJson(f.requires||\"[]\",\"REQ\"),writes=cleanWrites(parseJson(f.writes||\"[]\",\"WRITES\")),guards=await normalizeGuards(ws,parseJson(f.guards||\"[]\",\"GUARDS\"));if(!ws||!parent||!child||!dedupe||!Array.isArray(deps)||!Array.isArray(req)||!ctx||Array.isArray(ctx))throw new Error(\"BAD_DELEGATE\");\n const p:any=await one(`SELECT * FROM ${P}agents WHERE id=?`,[parent]),c:any=await one(`SELECT * FROM ${P}agents WHERE id=?`,[child]);if(!p)throw new Error(\"UNKNOWN_PARENT_AGENT\");if(!c)throw new Error(\"UNKNOWN_CHILD_AGENT\");if(String(p.workstream)!==ws||String(c.workstream)!==ws)throw new Error(\"CROSS_WORKSTREAM_DELEGATION_FORBIDDEN\");if(String(c.parent_id)!==parent)throw new Error(\"NOT_DIRECT_CHILD\");\n const existing:any=await one(`SELECT * FROM ${P}tasks WHERE workstream=? AND dedupe_key=? ORDER BY created_at DESC LIMIT 1`,[ws,dedupe]);if(existing){if(String(existing.assigned_agent)!==child||String(existing.delegated_by)!==parent)throw new Error(\"DEDUPE_KEY_DELEGATION_MISMATCH\");return{ok:true,created:false,task_id:existing.id,state:existing.state,assigned_agent:existing.assigned_agent,delegated_by:existing.delegated_by,lease_owner:existing.lease_owner,generation:await generation(),dedupe_key:dedupe}}\n for(const d of deps){const r:any=await one(`SELECT workstream,state FROM ${P}tasks WHERE id=?`,[d]);if(!r)throw new Error(\"UNKNOWN_DEP\");if(String(r.workstream)!==ws)throw new Error(\"CROSS_WORKSTREAM_DEP_FORBIDDEN\");if([\"INVALID\",\"BLOCKED\"].includes(String(r.state)))throw new Error(\"TERMINAL_DEPENDENCY\")}\n const t=now(),priority=Number(f.priority??0);await DB().execute({sql:`INSERT INTO ${P}tasks(id,workstream,state,priority,depends_json,success_condition,decision_value,context_manifest,lease_owner,lease_mode,lease_generation,lease_expires_at,created_at,updated_at,result_event_id,requires_json,dedupe_key,assigned_agent,delegated_by,writes_json,guards_json) VALUES(?,?,'READY',?,?,?,?,?,NULL,NULL,NULL,NULL,?,?,NULL,?,?,?,?,?,?)`,args:[id,ws,priority,canon(deps),String(f.success||\"\"),String(f.value||\"\"),canon(ctx),t,t,canon(req),dedupe,child,parent,canon(writes),canon(guards)]});\n await appendEvent(ws,parent,id,\"TASK_DELEGATED\",{priority,depends:deps,requires:req,writes,guards,dedupe_key:dedupe,assigned_agent:child,delegated_by:parent,success_condition:String(f.success||\"\"),decision_value:String(f.value||\"\")});const ng=await bump();await DB().execute({sql:`UPDATE ${P}workstreams SET head_generation=?,updated_at=? WHERE id=?`,args:[ng,now(),ws]});return{ok:true,created:true,task_id:id,state:\"READY\",generation:ng,dedupe_key:dedupe,assigned_agent:child,delegated_by:parent}\n}\nasync function supersedeContext(args:string[]){\n const f=flags(args,1),taskId=String(f.task||\"\"),agent=String(f.agent||\"\"),expected=Number(f[\"expected-workstream-generation\"]),newCtx=parseJson(f[\"new-context\"],\"NEW_CONTEXT\"),evidence=parseJson(f.evidence||\"[]\",\"EVIDENCE\");if(!taskId||!agent||!Number.isInteger(expected)||!newCtx||Array.isArray(newCtx)||!Array.isArray(evidence))throw new Error(\"BAD_SUPERSEDE\");\n const task:any=await one(`SELECT * FROM ${P}tasks WHERE id=?`,[taskId]),ag:any=await one(`SELECT * FROM ${P}agents WHERE id=?`,[agent]);if(!task||!ag)throw new Error(\"UNKNOWN_TASK_OR_AGENT\");if(String(task.workstream)!==String(ag.workstream))throw new Error(\"CROSS_WORKSTREAM_TASK_CONTEXT_SUPERSESSION_FORBIDDEN\");if(String(task.state)!==\"READY\")throw new Error(\"TASK_CONTEXT_SUPERSESSION_REQUIRES_READY\");\n const actual=Number((await one(`SELECT head_generation FROM ${P}workstreams WHERE id=?`,[task.workstream])).head_generation);if(actual!==expected)return{ok:false,reason:\"STALE_WORKSTREAM_WRITE\",expected,actual,workstream:task.workstream};await validateEvidenceRefs(evidence);const oldCtx=parseJson(task.context_manifest||\"{}\",\"CTX\");if(canon(oldCtx)===canon(newCtx))return{ok:true,changed:false,task_id:taskId,generation:await generation(),workstream_generation:actual};\n const ver=Number((await one(`SELECT COALESCE(MAX(version),0)+1 n FROM ${P}task_context_history WHERE task_id=?`,[taskId])).n),ev=await appendEvent(String(task.workstream),agent,taskId,\"TASK_CONTEXT_SUPERSEDED\",{version:ver,reason:String(f.reason||\"\"),evidence,old_context:oldCtx,new_context:newCtx}),eid=Number((await meta()).predecessor_event_count)+Number(ev.seq),hid=Number((await one(`SELECT COALESCE(MAX(id),0)+1 n FROM ${P}task_context_history`)).n);\n await DB().execute({sql:`INSERT INTO ${P}task_context_history(id,task_id,version,old_context_json,new_context_json,reason,evidence_json,agent_id,event_id,created_at) VALUES(?,?,?,?,?,?,?,?,?,?)`,args:[hid,taskId,ver,canon(oldCtx),canon(newCtx),String(f.reason||\"\"),canon(evidence),agent,eid,now()]});await DB().execute({sql:`UPDATE ${P}tasks SET context_manifest=?,updated_at=? WHERE id=?`,args:[canon(newCtx),now(),taskId]});const ng=await bump();await DB().execute({sql:`UPDATE ${P}agents SET last_generation=?,last_seen=? WHERE id=?`,args:[ng,now(),agent]});await DB().execute({sql:`UPDATE ${P}workstreams SET head_generation=?,updated_at=? WHERE id=?`,args:[ng,now(),task.workstream]});return{ok:true,changed:true,task_id:taskId,version:ver,generation:ng,workstream_generation:ng,event_id:eid}\n}\nasync function ensureTaskInvariantRequiresColumns(){\n const r:any=await DB().execute(`PRAGMA table_info(${P}task_invariant_history)`),names=new Set((r.rows||[]).map((x:any)=>String(x.name)));\n if(!names.has(\"old_requires_json\"))await DB().execute(`ALTER TABLE ${P}task_invariant_history ADD COLUMN old_requires_json TEXT`);\n if(!names.has(\"new_requires_json\"))await DB().execute(`ALTER TABLE ${P}task_invariant_history ADD COLUMN new_requires_json TEXT`);\n}\nasync function migrateInvariants(args:string[]){\n const f=flags(args,1),taskId=String(f.task||\"\"),agent=String(f.agent||\"\"),expected=Number(f[\"expected-workstream-generation\"]),dedupe=String(f[\"dedupe-key\"]||\"\"),writes=cleanWrites(parseJson(f.writes||\"[]\",\"WRITES\")),evidence=parseJson(f.evidence||\"[]\",\"EVIDENCE\"),hasRequires=Object.prototype.hasOwnProperty.call(f,\"requires\"),requiresOverride=hasRequires?cleanCaps(parseJson(f.requires,\"REQUIRES\")):null;if(!taskId||!agent||!Number.isInteger(expected)||!dedupe||!Array.isArray(evidence))throw new Error(\"BAD_MIGRATE\");\n const task:any=await one(`SELECT * FROM ${P}tasks WHERE id=?`,[taskId]),ag:any=await one(`SELECT * FROM ${P}agents WHERE id=?`,[agent]);if(!task||!ag)throw new Error(\"UNKNOWN_TASK_OR_AGENT\");if(String(task.workstream)!==String(ag.workstream))throw new Error(\"CROSS_WORKSTREAM_TASK_MIGRATION_FORBIDDEN\");if(String(task.state)!==\"READY\")throw new Error(\"TASK_MIGRATION_REQUIRES_READY\");const guards=await normalizeGuards(String(task.workstream),parseJson(f.guards||\"[]\",\"GUARDS\"));\n const actual=Number((await one(`SELECT head_generation FROM ${P}workstreams WHERE id=?`,[task.workstream])).head_generation);if(actual!==expected)return{ok:false,reason:\"STALE_WORKSTREAM_WRITE\",expected,actual,workstream:task.workstream};await validateEvidenceRefs(evidence);const conflict:any=await one(`SELECT id,state FROM ${P}tasks WHERE workstream=? AND dedupe_key=? AND id<>? AND state IN ('READY','LEASED') LIMIT 1`,[task.workstream,dedupe,taskId]);if(conflict)throw new Error(\"OPEN_DEDUPE_CONFLICT\");\n const oldD=task.dedupe_key,oldW=String(task.writes_json||\"[]\"),oldG=String(task.guards_json||\"[]\"),oldR=String(task.requires_json||\"[]\"),oldReq=parseJson(oldR,\"OLDREQ\");if(!Array.isArray(oldReq))throw new Error(\"OLD_REQUIRES_NOT_LIST\");const newReq=hasRequires?requiresOverride:oldReq,newR=hasRequires?canon(newReq):oldR;if(String(oldD)===dedupe&&canon(parseJson(oldW,\"OLDW\"))===canon(writes)&&canon(parseJson(oldG,\"OLDG\"))===canon(guards)&&canon(oldReq)===canon(newReq))return{ok:true,changed:false,task_id:taskId,generation:await generation(),workstream_generation:actual};\n await ensureTaskInvariantRequiresColumns();const ver=Number((await one(`SELECT COALESCE(MAX(version),0)+1 n FROM ${P}task_invariant_history WHERE task_id=?`,[taskId])).n),ev=await appendEvent(String(task.workstream),agent,taskId,\"TASK_INVARIANTS_MIGRATED\",{version:ver,reason:String(f.reason||\"\"),evidence,old_dedupe_key:oldD,new_dedupe_key:dedupe,old_writes:parseJson(oldW,\"OLDW\"),new_writes:writes,old_guards:parseJson(oldG,\"OLDG\"),new_guards:guards,old_requires:oldReq,new_requires:newReq}),eid=Number((await meta()).predecessor_event_count)+Number(ev.seq),hid=Number((await one(`SELECT COALESCE(MAX(id),0)+1 n FROM ${P}task_invariant_history`)).n);\n await DB().execute({sql:`INSERT INTO ${P}task_invariant_history(id,task_id,version,old_dedupe_key,new_dedupe_key,old_writes_json,new_writes_json,old_guards_json,new_guards_json,old_requires_json,new_requires_json,reason,evidence_json,agent_id,event_id,created_at) VALUES(?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?)`,args:[hid,taskId,ver,oldD,dedupe,oldW,canon(writes),oldG,canon(guards),oldR,newR,String(f.reason||\"\"),canon(evidence),agent,eid,now()]});await DB().execute({sql:`UPDATE ${P}tasks SET dedupe_key=?,writes_json=?,guards_json=?,requires_json=?,updated_at=? WHERE id=?`,args:[dedupe,canon(writes),canon(guards),newR,now(),taskId]});const ng=await bump();await DB().execute({sql:`UPDATE ${P}agents SET last_generation=?,last_seen=? WHERE id=?`,args:[ng,now(),agent]});await DB().execute({sql:`UPDATE ${P}workstreams SET head_generation=?,updated_at=? WHERE id=?`,args:[ng,now(),task.workstream]});return{ok:true,changed:true,task_id:taskId,version:ver,generation:ng,workstream_generation:ng,event_id:eid,dedupe_key:dedupe,writes,guards,requires:newReq}\n}\nasync function reconcileCausal(args:string[]){\n const f=flags(args,1),ws=String(f.workstream||\"\"),agent=String(f.agent||\"\"),expected=Number(f[\"expected-workstream-generation\"]);if(!ws||!agent||!Number.isInteger(expected))throw new Error(\"BAD_RECONCILE\");const ag:any=await one(`SELECT workstream FROM ${P}agents WHERE id=?`,[agent]);if(!ag)throw new Error(\"UNKNOWN_AGENT\");if(String(ag.workstream)!==ws)throw new Error(\"CROSS_WORKSTREAM_RECONCILIATION_FORBIDDEN\");const actual=Number((await one(`SELECT head_generation FROM ${P}workstreams WHERE id=?`,[ws])).head_generation);if(actual!==expected)return{ok:false,reason:\"STALE_WORKSTREAM_WRITE\",expected,actual,workstream:ws};const changed=await propagateImpossible(ws,agent,{type:\"historical_reconcile\"});let ng=await generation();if(changed.length){ng=await bump();await DB().execute({sql:`UPDATE ${P}workstreams SET head_generation=?,updated_at=? WHERE id=?`,args:[ng,now(),ws]});await DB().execute({sql:`UPDATE ${P}agents SET last_generation=?,last_seen=? WHERE id=?`,args:[ng,now(),agent]})}return{ok:true,changed_count:changed.length,changed,generation:ng,workstream_generation:changed.length?ng:actual,workstream:ws}\n}\nasync function addClaimFull(args:string[]){\n if(args.length<2)throw new Error(\"CLAIM_ID_REQUIRED\");const id=args[1],f=flags(args,2),ws=String(f.workstream||\"\"),status0=String(f.status||\"VERIFIED\"),statement=parseJson(f.statement,\"STATEMENT\"),evidence=parseJson(f.evidence||\"[]\",\"EVIDENCE\"),deps=parseJson(f.depends||\"[]\",\"DEPS\");if(!ws||![\"VERIFIED\",\"CANDIDATE\",\"HYPOTHESIS\"].includes(status0)||!statement||Array.isArray(statement)||!Array.isArray(evidence)||!Array.isArray(deps))throw new Error(\"BAD_CLAIM\");if(!await one(`SELECT id FROM ${P}workstreams WHERE id=?`,[ws]))throw new Error(\"UNKNOWN_WORKSTREAM\");await validateEvidenceRefs(evidence);\n for(const d of deps){const r:any=await one(`SELECT workstream,status FROM ${P}claims WHERE id=?`,[d]);if(!r)throw new Error(\"UNKNOWN_CLAIM_DEP\");if(String(r.workstream)!==ws)throw new Error(\"CROSS_WORKSTREAM_CLAIM_DEP_FORBIDDEN\");if(String(r.status)!==\"VERIFIED\")throw new Error(\"NONVERIFIED_CLAIM_DEP\")}\n const raw=canon(statement),h=await sha(raw),g0=await generation(),t=now();if(await one(`SELECT id FROM ${P}claims WHERE id=?`,[id]))throw new Error(\"CLAIM_EXISTS\");await DB().execute({sql:`INSERT INTO ${P}claims(id,workstream,status,statement_json,statement_sha256,evidence_json,created_generation,invalidated_by,created_at,updated_at) VALUES(?,?,?,?,?,?,?,NULL,?,?)`,args:[id,ws,status0,raw,h,canon(evidence),g0,t,t]});for(const d of deps)await DB().execute({sql:`INSERT INTO ${P}claim_deps(parent_claim,child_claim) VALUES(?,?)`,args:[d,id]});await appendEvent(ws,f.agent??null,null,\"CLAIM_ADDED\",{claim_id:id,status:status0,statement_sha256:h,evidence,depends:deps});const ng=await bump();await DB().execute({sql:`UPDATE ${P}workstreams SET head_generation=?,updated_at=? WHERE id=?`,args:[ng,now(),ws]});return{ok:true,claim_id:id,statement_sha256:h,generation:ng}\n}\nasync function invalidateClaimFull(args:string[]){\n if(args.length<2)throw new Error(\"CLAIM_ID_REQUIRED\");const id=args[1],f=flags(args,2),reason=String(f.reason||\"\"),agent=f.agent??null;const root:any=await one(`SELECT workstream,status FROM ${P}claims WHERE id=?`,[id]);if(!root)throw new Error(\"UNKNOWN_CLAIM\");const todo=[id],seen=new Set(),changed:any[]=[];\n while(todo.length){const q=String(todo.pop());if(seen.has(q))continue;seen.add(q);const row:any=await one(`SELECT status FROM ${P}claims WHERE id=?`,[q]);if(row&&![\"FALSIFIED\",\"STALE\"].includes(String(row.status))){const ns=q===id?\"FALSIFIED\":\"STALE\";await DB().execute({sql:`UPDATE ${P}claims SET status=?,invalidated_by=?,updated_at=? WHERE id=?`,args:[ns,id,now(),q]});changed.push([q,ns])}const kids:any[]=(await DB().execute({sql:`SELECT child_claim FROM ${P}claim_deps WHERE parent_claim=?`,args:[q]})).rows as any[];for(const k of kids)todo.push(String(k.child_claim))}\n await appendEvent(String(root.workstream),agent,null,\"CLAIM_INVALIDATED\",{root_claim:id,reason,affected:changed});const propagated=await propagateImpossible(String(root.workstream),agent,{type:\"claim_invalidated\",claim_id:id,reason});const ng=await bump();await DB().execute({sql:`UPDATE ${P}workstreams SET head_generation=?,updated_at=? WHERE id=?`,args:[ng,now(),root.workstream]});return{ok:true,root_claim:id,affected:changed,generation:ng,propagated_blocked:propagated}\n}\nasync function commitFull(args:string[]){\n const f=flags(args,1),agent=String(f.agent||\"\"),taskId=String(f.task||\"\"),state=String(f.state||\"COMPLETE\");if(!agent||!taskId||![\"COMPLETE\",\"INVALID\",\"BLOCKED\"].includes(state))throw new Error(\"BAD_COMMIT\");const task:any=await one(`SELECT * FROM ${P}tasks WHERE id=?`,[taskId]),ag:any=await one(`SELECT * FROM ${P}agents WHERE id=?`,[agent]);if(!task||!ag)throw new Error(\"UNKNOWN_TASK_OR_AGENT\");if(String(task.workstream)!==String(ag.workstream))throw new Error(\"CROSS_WORKSTREAM_COMMIT_FORBIDDEN\");if(String(task.lease_owner)!==agent)throw new Error(\"NOT_LEASE_OWNER\");if(task.lease_expires_at&&String(task.lease_expires_at)Promise){\n const tx:any=await (sqlite as any).transaction(mode);\n try{\n const value=await dbScope.run(tx,fn);\n await tx.commit();\n return value;\n }catch(e){\n try{await tx.rollback()}catch{}\n throw e;\n }\n}\nasync function dispatchFull(payloadJson:string){\n const q=parseJson(payloadJson,\"PAYLOAD\");\n if(!exactTop(q))throw new Error(\"PAYLOAD_SCHEMA_NOT_CLOSED\");\n const cmd=String(q.args[0]);\n const readOnly=new Set([\"status\",\"verify-chain\",\"verify-claim-graph\"]);\n return await withDbTransaction(readOnly.has(cmd)?\"read\":\"write\",()=>dispatchCore(payloadJson));\n}\nasync function statusTxn(){return await withDbTransaction(\"read\",()=>status())}\nasync function verifyChainTxn(){return await withDbTransaction(\"read\",()=>verifyChain())}\nasync function verifyClaimGraphTxn(){return await withDbTransaction(\"read\",()=>verifyClaimGraph())}\nasync function checkpointTxn(){return await withDbTransaction(\"write\",()=>checkpointNative())}\nasync function recoverTxn(){return await withDbTransaction(\"write\",()=>recover())}\nasync function registerTxn(args:string[]){return await withDbTransaction(\"write\",()=>register(args))}\nasync function claimTxn(args:string[]){return await withDbTransaction(\"write\",()=>claim(args))}\n\n\n\nexport {\n dispatchFull as dispatchBrain,\n statusTxn as brainStatus,\n verifyChainTxn as verifyBrainChain,\n verifyClaimGraphTxn as verifyBrainClaimGraph,\n checkpointTxn as checkpointBrainNative,\n recoverTxn as recoverBrainStale,\n registerTxn as registerBrainAgent,\n claimTxn as claimBrainTask,\n generation as brainGeneration\n};\n",[146],"786394b4-7a2c-49aa-b114-4bd3b8eedf2b","main.ts","1e728a38-aaaf-11f1-8d2e-1607ee4eb77e",["D",1788780453152],"export default function(){return 'disposable';}\n",[155],"458333f1-3947-4089-98bf-29ce4de7eaa6","epoch3_recovery_test.ts","2ed0de7e-aab0-11f1-bd0c-1607ee4eb77e",7,["D",1788780910131],"import { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\nconst P=\"r_\";\nconst enc=new TextEncoder();\nconst now=()=>new Date().toISOString().replace(\"Z\",\"+00:00\");\nfunction canon(x:any):string{if(x===null||typeof x!==\"object\")return JSON.stringify(x);if(Array.isArray(x))return \"[\"+x.map(canon).join(\",\")+\"]\";return \"{\"+Object.keys(x).sort().map(k=>JSON.stringify(k)+\":\"+canon(x[k])).join(\",\")+\"}\"}\nasync function sha(s:string){const d=await crypto.subtle.digest(\"SHA-256\",enc.encode(s));return [...new Uint8Array(d)].map(x=>x.toString(16).padStart(2,\"0\")).join(\"\")}\nasync function one(db:any,sql:string,args:any[]=[]){return (await db.execute({sql,args})).rows?.[0]??null}\nasync function mkEvent(seq:number,prev:string,type:string,agent:string|null,task:string|null,g:number){\n const e={event_uuid:crypto.randomUUID(),ts:now(),workstream:\"global\",agent_id:agent,task_id:task,type,payload:{seq},prev_hash:prev};\n const h=await sha(canon(e));\n await sqlite.execute({sql:`INSERT INTO ${P}epoch_events VALUES(?,?,?,?,?,?,?,?,?,?,?)`,args:[seq,e.event_uuid,e.ts,e.workstream,agent,task,type,canon(e.payload),prev,h,g]});\n return h;\n}\nasync function reset(){\n for(const t of [\"epoch_events_archive_epoch2\",\"epoch_meta_archive_epoch2\",\"control\",\"tasks\",\"agents\",\"workstreams\",\"epoch_events\",\"epoch_meta\"])await sqlite.execute(`DROP TABLE IF EXISTS ${P}${t}`);\n await sqlite.execute(`CREATE TABLE ${P}control(id INTEGER PRIMARY KEY,epoch INTEGER,writer TEXT,mode TEXT,updated_at TEXT)`);\n await sqlite.execute(`CREATE TABLE ${P}epoch_meta(id INTEGER PRIMARY KEY,epoch INTEGER,predecessor_generation INTEGER,predecessor_event_count INTEGER,predecessor_head TEXT,generation INTEGER,event_head_hash TEXT,new_event_count INTEGER,recovered_count INTEGER,ordering_policy TEXT,classification TEXT,created_at TEXT)`);\n await sqlite.execute(`CREATE TABLE ${P}epoch_events(local_seq INTEGER PRIMARY KEY,event_uuid TEXT UNIQUE,ts TEXT,workstream TEXT,agent_id TEXT,task_id TEXT,type TEXT,payload_json TEXT,prev_hash TEXT,event_hash TEXT UNIQUE,transaction_generation INTEGER)`);\n await sqlite.execute(`CREATE TABLE ${P}workstreams(id TEXT PRIMARY KEY,head_generation INTEGER,updated_at TEXT)`);\n await sqlite.execute(`CREATE TABLE ${P}agents(id TEXT PRIMARY KEY,status TEXT,last_generation INTEGER,last_seen TEXT)`);\n await sqlite.execute(`CREATE TABLE ${P}tasks(id TEXT PRIMARY KEY,workstream TEXT,state TEXT,lease_owner TEXT,lease_mode TEXT,lease_generation INTEGER,lease_expires_at TEXT,result_event_id INTEGER,updated_at TEXT)`);\n const base=\"c\".repeat(64);\n await sqlite.batch([\n {sql:`INSERT INTO ${P}control VALUES(1,2,'val_native','PREPARED',?)`,args:[now()]},\n {sql:`INSERT INTO ${P}workstreams VALUES('global',14,?)`,args:[now()]},\n {sql:`INSERT INTO ${P}agents VALUES('Z','READY',11,?)`,args:[now()]},\n {sql:`INSERT INTO ${P}agents VALUES('Q','READY',12,?)`,args:[now()]},\n {sql:`INSERT INTO ${P}tasks VALUES('ORPHAN','global','LEASED','Z','INTERACTIVE',12,?,NULL,?)`,args:[new Date(Date.now()+600000).toISOString().replace(\"Z\",\"+00:00\"),now()]},\n {sql:`INSERT INTO ${P}tasks VALUES('DONE','global','COMPLETE',NULL,NULL,NULL,NULL,104,?)`,args:[now()]}\n ]);\n const e1=await mkEvent(1,base,\"AGENT_REGISTERED\",\"Z\",null,10);\n const e2=await mkEvent(2,e1,\"TASK_LEASED\",\"Z\",\"ORPHAN\",11);\n const e3=await mkEvent(3,e1,\"AGENT_REGISTERED\",\"Q\",null,11);\n const e4=await mkEvent(4,e3,\"TASK_RESULT_COMMITTED\",\"Q\",\"DONE\",12);\n await sqlite.execute({sql:`INSERT INTO ${P}epoch_meta VALUES(1,2,9,100,?,14,?,4,0,'TEST','FORKED',?)`,args:[base,e4,now()]});\n return {base,e1,e2,e3,e4};\n}\nasync function stateHash(tx:any){\n const ws=(await tx.execute(`SELECT * FROM ${P}workstreams ORDER BY id`)).rows;\n const ag=(await tx.execute(`SELECT * FROM ${P}agents ORDER BY id`)).rows;\n const ta=(await tx.execute(`SELECT * FROM ${P}tasks ORDER BY id`)).rows;\n return await sha(canon({workstreams:ws,agents:ag,tasks:ta}));\n}\nasync function recoverEpoch3(expect:any){\n const tx:any=await (sqlite as any).transaction(\"write\");\n try{\n const c:any=await one(tx,`SELECT * FROM ${P}control WHERE id=1`);\n const m:any=await one(tx,`SELECT * FROM ${P}epoch_meta WHERE id=1`);\n if(!c||c.writer!==\"val_native\"||c.mode!==\"PREPARED\"||Number(c.epoch)!==2)throw new Error(\"AUTHORITY_NOT_FENCED_EPOCH2\");\n if(!m||Number(m.epoch)!==2||Number(m.generation)!==14)throw new Error(\"UNEXPECTED_META\");\n const dup:any[]=(await tx.execute(`SELECT prev_hash,COUNT(*) n,GROUP_CONCAT(local_seq) seqs FROM ${P}epoch_events GROUP BY prev_hash HAVING COUNT(*)>1`)).rows as any[];\n if(dup.length!==1||String(dup[0].prev_hash)!==expect.e1)throw new Error(\"FORK_SHAPE_MISMATCH\");\n const orphan:any=await one(tx,`SELECT * FROM ${P}epoch_events WHERE local_seq=2`);\n if(!orphan||orphan.event_hash!==expect.e2||orphan.type!==\"TASK_LEASED\"||orphan.task_id!==\"ORPHAN\"||orphan.agent_id!==\"Z\")throw new Error(\"ORPHAN_EVENT_MISMATCH\");\n const task:any=await one(tx,`SELECT * FROM ${P}tasks WHERE id='ORPHAN'`);\n if(!task||task.state!==\"LEASED\"||task.lease_owner!==\"Z\"||Number(task.lease_generation)!==12||task.result_event_id!==null)throw new Error(\"PARTIAL_LEASE_MISMATCH\");\n await tx.execute(`CREATE TABLE ${P}epoch_events_archive_epoch2 AS SELECT * FROM ${P}epoch_events`);\n await tx.execute(`CREATE TABLE ${P}epoch_meta_archive_epoch2 AS SELECT * FROM ${P}epoch_meta`);\n await tx.execute({sql:`UPDATE ${P}tasks SET state='READY',lease_owner=NULL,lease_mode=NULL,lease_generation=NULL,lease_expires_at=NULL,updated_at=? WHERE id='ORPHAN' AND state='LEASED' AND lease_owner='Z' AND lease_generation=12 RETURNING id`,args:[now()]});\n const sh=await stateHash(tx);\n await tx.execute(`DELETE FROM ${P}epoch_events`);\n const preGen=11,preCount=101,preHead=expect.e1,newGen=15;\n const payload={schema:\"RECOVERY_ANCHOR_V1\",source_epoch:2,last_good_local_seq:1,last_good_head:preHead,archived_fork:{seq2:expect.e2,seq3:expect.e3,seq4:expect.e4},reconciled_partial_lease:{task:\"ORPHAN\",previous_owner:\"Z\",lease_generation:12},carried_state_sha256:sh};\n const e={event_uuid:crypto.randomUUID(),ts:now(),workstream:\"global\",agent_id:null,task_id:\"ORPHAN\",type:\"CONTROL_PLANE_FORK_RECOVERY_ANCHORED\",payload,prev_hash:preHead};\n const h=await sha(canon(e));\n await tx.execute({sql:`INSERT INTO ${P}epoch_events VALUES(1,?,?,?,?,?,?,?,?,?,?)`,args:[e.event_uuid,e.ts,e.workstream,null,e.task_id,e.type,canon(payload),preHead,h,14]});\n await tx.execute({sql:`UPDATE ${P}epoch_meta SET epoch=3,predecessor_generation=?,predecessor_event_count=?,predecessor_head=?,generation=?,event_head_hash=?,new_event_count=1,recovered_count=recovered_count+1,ordering_policy='FORMAL_FORK_RECOVERY_ANCHOR_V1',classification='RECOVERY_EPOCH3_CANDIDATE_NONAUTHORITY',created_at=? WHERE id=1 AND epoch=2 AND generation=14 RETURNING id`,args:[preGen,preCount,preHead,newGen,h,now()]});\n await tx.execute({sql:`UPDATE ${P}workstreams SET head_generation=?,updated_at=? WHERE id='global'`,args:[newGen,now()]});\n await tx.commit();\n return {ok:true,new_generation:newGen,new_head:h,state_sha256:sh};\n }catch(e){try{await tx.rollback()}catch{};return {ok:false,error:String((e as Error).message)}}\n}\nasync function verify(){\n const m:any=await one(sqlite,`SELECT * FROM ${P}epoch_meta WHERE id=1`);\n const es:any[]=(await sqlite.execute(`SELECT * FROM ${P}epoch_events ORDER BY local_seq`)).rows as any[];\n let prev=String(m.predecessor_head),bad:any[]=[];\n for(const r of es){const payload=JSON.parse(String(r.payload_json));const h=await sha(canon({event_uuid:r.event_uuid,ts:r.ts,workstream:r.workstream,agent_id:r.agent_id,task_id:r.task_id,type:r.type,payload,prev_hash:r.prev_hash}));if(r.prev_hash!==prev||r.event_hash!==h)bad.push(r.local_seq);prev=r.event_hash}\n return {ok:bad.length===0&&prev===m.event_head_hash&&es.length===Number(m.new_event_count),bad,meta:m};\n}\nconst f=await reset();\nconst beforeDup=(await sqlite.execute(`SELECT prev_hash,COUNT(*) n,GROUP_CONCAT(local_seq) seqs FROM ${P}epoch_events GROUP BY prev_hash HAVING COUNT(*)>1`)).rows;\nconst first=await recoverEpoch3(f);\nconst v=await verify();\nconst archived=Number((await one(sqlite,`SELECT COUNT(*) n FROM ${P}epoch_events_archive_epoch2`)).n);\nconst archiveDup=(await sqlite.execute(`SELECT prev_hash,COUNT(*) n,GROUP_CONCAT(local_seq) seqs FROM ${P}epoch_events_archive_epoch2 GROUP BY prev_hash HAVING COUNT(*)>1`)).rows;\nconst task=await one(sqlite,`SELECT * FROM ${P}tasks WHERE id='ORPHAN'`);\nconst second=await recoverEpoch3(f);\nconst control=await one(sqlite,`SELECT * FROM ${P}control WHERE id=1`);\nconst pass=beforeDup.length===1&&first.ok&&v.ok&&archived===4&&archiveDup.length===1&&task.state===\"READY\"&&task.lease_owner===null&&!second.ok&&control.mode===\"PREPARED\"&&Number(v.meta.epoch)===3;\nconsole.log(JSON.stringify({schema:\"BRAIN_EPOCH3_FORMAL_FORK_RECOVERY_DISPOSABLE_FALSIFICATION_V1\",classification:\"NONAUTHORITY_DISPOSABLE_TEST\",beforeDup,first,verify:v,archived,archiveDup,task,second,control,pass,direct_sprites_calls:0,human_authority_approval:false},null,2));\n",[161],"248ed618-35c0-47ea-aac0-82901b586025",["D",1788781241361],2,[28],"32d76f94-e8a3-4cfe-b073-94b711c73382","atomic_core_test.ts","46507f9c-aaaf-11f1-a7c5-1607ee4eb77e",["D",1788780520060],"import { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\nimport { blob } from \"https://esm.town/v/std/blob/main.ts\";\n\nconst P=\"t_\";\nconst enc=new TextEncoder();\nfunction now(){return new Date().toISOString().replace(\"Z\",\"+00:00\")}\nfunction canon(x:any):string{\n if(x===null||typeof x!==\"object\")return JSON.stringify(x);\n if(Array.isArray(x))return \"[\"+x.map(canon).join(\",\")+\"]\";\n return \"{\"+Object.keys(x).sort().map(k=>JSON.stringify(k)+\":\"+canon(x[k])).join(\",\")+\"}\";\n}\nasync function sha(s:string){const d=await crypto.subtle.digest(\"SHA-256\",enc.encode(s));return [...new Uint8Array(d)].map(x=>x.toString(16).padStart(2,\"0\")).join(\"\")}\nasync function one(db:any,sql:string,args:any[]=[]){return (await db.execute({sql,args})).rows?.[0]??null}\nasync function reset(){\n for(const t of [\"epoch_events\",\"epoch_meta\",\"tasks\",\"agents\",\"workstreams\"])await sqlite.execute(`DROP TABLE IF EXISTS ${P}${t}`);\n await sqlite.execute(`CREATE TABLE ${P}epoch_meta(\n id INTEGER PRIMARY KEY CHECK(id=1),epoch INTEGER NOT NULL,predecessor_generation INTEGER NOT NULL,\n predecessor_event_count INTEGER NOT NULL,predecessor_head TEXT NOT NULL,generation INTEGER NOT NULL,\n event_head_hash TEXT NOT NULL,new_event_count INTEGER NOT NULL,recovered_count INTEGER NOT NULL,\n ordering_policy TEXT NOT NULL,classification TEXT NOT NULL,created_at TEXT NOT NULL)`);\n await sqlite.execute(`CREATE TABLE ${P}epoch_events(\n local_seq INTEGER PRIMARY KEY,event_uuid TEXT UNIQUE NOT NULL,ts TEXT NOT NULL,workstream TEXT NOT NULL,\n agent_id TEXT,task_id TEXT,type TEXT NOT NULL,payload_json TEXT NOT NULL,prev_hash TEXT NOT NULL,\n event_hash TEXT UNIQUE NOT NULL,transaction_generation INTEGER NOT NULL)`);\n await sqlite.execute(`CREATE TABLE ${P}workstreams(id TEXT PRIMARY KEY,head_generation INTEGER NOT NULL,updated_at TEXT NOT NULL)`);\n await sqlite.execute(`CREATE TABLE ${P}agents(id TEXT PRIMARY KEY,workstream TEXT NOT NULL,status TEXT NOT NULL,boot_generation INTEGER NOT NULL,last_generation INTEGER NOT NULL,last_seen TEXT NOT NULL)`);\n await sqlite.execute(`CREATE TABLE ${P}tasks(id TEXT PRIMARY KEY,workstream TEXT NOT NULL,state TEXT NOT NULL,lease_owner TEXT,lease_mode TEXT,lease_generation INTEGER,lease_expires_at TEXT,result_event_id INTEGER,updated_at TEXT NOT NULL)`);\n const h=\"a\".repeat(64);\n await sqlite.batch([\n {sql:`INSERT INTO ${P}epoch_meta VALUES(1,3,10,100,?,10,?,0,0,'TEST','DISPOSABLE',?)`,args:[h,h,now()]},\n {sql:`INSERT INTO ${P}workstreams VALUES('global',10,?)`,args:[now()]},\n {sql:`INSERT INTO ${P}tasks VALUES('T1','global','READY',NULL,NULL,NULL,NULL,NULL,?)`,args:[now()]},\n {sql:`INSERT INTO ${P}tasks VALUES('T2','global','READY',NULL,NULL,NULL,NULL,NULL,?)`,args:[now()]}\n ]);\n}\nasync function appendEvent(tx:any,ws:string,agent:string|null,task:string|null,type:string,payload:any,g:number){\n const m:any=await one(tx,`SELECT * FROM ${P}epoch_meta WHERE id=1`);\n const tail:any=await one(tx,`SELECT event_hash FROM ${P}epoch_events ORDER BY local_seq DESC LIMIT 1`);\n const expectedTail=tail?String(tail.event_hash):String(m.predecessor_head);\n if(expectedTail!==String(m.event_head_hash))throw new Error(\"HEAD_TAIL_MISMATCH\");\n const seq=Number((await one(tx,`SELECT COALESCE(MAX(local_seq),0)+1 AS n FROM ${P}epoch_events`)).n);\n const e={event_uuid:crypto.randomUUID(),ts:now(),workstream:ws,agent_id:agent,task_id:task,type,payload,prev_hash:expectedTail};\n const h=await sha(canon(e));\n await tx.execute({sql:`INSERT INTO ${P}epoch_events(local_seq,event_uuid,ts,workstream,agent_id,task_id,type,payload_json,prev_hash,event_hash,transaction_generation)\n VALUES(?,?,?,?,?,?,?,?,?,?,?)`,args:[seq,e.event_uuid,e.ts,ws,agent,task,type,canon(payload),expectedTail,h,g]});\n const u:any=await tx.execute({sql:`UPDATE ${P}epoch_meta SET event_head_hash=?,new_event_count=new_event_count+1 WHERE id=1 AND event_head_hash=? RETURNING id`,args:[h,expectedTail]});\n if((u.rows||[]).length!==1)throw new Error(\"HEAD_CAS_LOST\");\n return {seq,event_hash:h};\n}\nasync function bump(tx:any,g:number){\n const u:any=await tx.execute({sql:`UPDATE ${P}epoch_meta SET generation=? WHERE id=1 AND generation=? RETURNING generation`,args:[g+1,g]});\n if((u.rows||[]).length!==1)throw new Error(\"GENERATION_CAS_LOST\");\n return g+1;\n}\nasync function atomicRegister(id:string,inject:\"none\"|\"after_agent\"|\"after_event\"=\"none\"){\n const tx:any=await (sqlite as any).transaction(\"write\");\n try{\n const m:any=await one(tx,`SELECT generation FROM ${P}epoch_meta WHERE id=1`); const g=Number(m.generation);\n if(await one(tx,`SELECT id FROM ${P}agents WHERE id=?`,[id]))throw new Error(\"AGENT_EXISTS\");\n await tx.execute({sql:`INSERT INTO ${P}agents VALUES(?,'global','READY',?,?,?)`,args:[id,g,g,now()]});\n if(inject===\"after_agent\")throw new Error(\"INJECT_AFTER_AGENT\");\n await appendEvent(tx,\"global\",id,null,\"AGENT_REGISTERED\",{role:\"fixture\"},g);\n if(inject===\"after_event\")throw new Error(\"INJECT_AFTER_EVENT\");\n const ng=await bump(tx,g);\n await tx.execute({sql:`UPDATE ${P}agents SET last_generation=?,last_seen=? WHERE id=?`,args:[ng,now(),id]});\n await tx.execute({sql:`UPDATE ${P}workstreams SET head_generation=?,updated_at=? WHERE id='global'`,args:[ng,now()]});\n await tx.commit(); return {ok:true,id,generation:ng};\n }catch(e){try{await tx.rollback()}catch{};return {ok:false,error:String((e as Error).message)}}\n}\nasync function atomicClaim(agent:string,task:string,inject:\"none\"|\"after_task\"|\"after_event\"=\"none\"){\n const tx:any=await (sqlite as any).transaction(\"write\");\n try{\n const a:any=await one(tx,`SELECT * FROM ${P}agents WHERE id=?`,[agent]); if(!a||a.status!==\"READY\")throw new Error(\"AGENT_NOT_READY\");\n const t:any=await one(tx,`SELECT * FROM ${P}tasks WHERE id=?`,[task]); if(!t||t.state!==\"READY\")throw new Error(\"TASK_NOT_READY\");\n const g=Number((await one(tx,`SELECT generation FROM ${P}epoch_meta WHERE id=1`)).generation);\n const exp=new Date(Date.now()+900000).toISOString().replace(\"Z\",\"+00:00\");\n const u:any=await tx.execute({sql:`UPDATE ${P}tasks SET state='LEASED',lease_owner=?,lease_mode='INTERACTIVE',lease_generation=?,lease_expires_at=?,updated_at=? WHERE id=? AND state='READY' RETURNING id`,args:[agent,g,exp,now(),task]});\n if((u.rows||[]).length!==1)throw new Error(\"CLAIM_RACE_LOST\");\n if(inject===\"after_task\")throw new Error(\"INJECT_AFTER_TASK\");\n await appendEvent(tx,\"global\",agent,task,\"TASK_LEASED\",{lease_generation:g,lease_expires_at:exp},g);\n if(inject===\"after_event\")throw new Error(\"INJECT_AFTER_EVENT\");\n const ng=await bump(tx,g);\n await tx.execute({sql:`UPDATE ${P}agents SET status='WORKING',last_generation=?,last_seen=? WHERE id=?`,args:[ng,now(),agent]});\n await tx.execute({sql:`UPDATE ${P}workstreams SET head_generation=?,updated_at=? WHERE id='global'`,args:[ng,now()]});\n await tx.commit();return {ok:true,agent,task,generation:ng,lease_generation:g};\n }catch(e){try{await tx.rollback()}catch{};return {ok:false,agent,task,error:String((e as Error).message)}}\n}\nasync function atomicCommit(agent:string,task:string,inject:\"none\"|\"after_event\"=\"none\"){\n const tx:any=await (sqlite as any).transaction(\"write\");\n try{\n const t:any=await one(tx,`SELECT * FROM ${P}tasks WHERE id=?`,[task]);\n if(!t||t.state!==\"LEASED\"||t.lease_owner!==agent)throw new Error(\"NOT_LEASE_OWNER\");\n const g=Number((await one(tx,`SELECT generation FROM ${P}epoch_meta WHERE id=1`)).generation);\n const ev=await appendEvent(tx,\"global\",agent,task,\"TASK_RESULT_COMMITTED\",{result:\"PASS\"},g);\n if(inject===\"after_event\")throw new Error(\"INJECT_AFTER_EVENT\");\n const u:any=await tx.execute({sql:`UPDATE ${P}tasks SET state='COMPLETE',result_event_id=?,lease_owner=NULL,lease_mode=NULL,lease_generation=NULL,lease_expires_at=NULL,updated_at=? WHERE id=? AND state='LEASED' AND lease_owner=? RETURNING id`,args:[100+ev.seq,now(),task,agent]});\n if((u.rows||[]).length!==1)throw new Error(\"COMMIT_RACE_LOST\");\n const ng=await bump(tx,g);\n await tx.execute({sql:`UPDATE ${P}agents SET status='READY',last_generation=?,last_seen=? WHERE id=?`,args:[ng,now(),agent]});\n await tx.execute({sql:`UPDATE ${P}workstreams SET head_generation=?,updated_at=? WHERE id='global'`,args:[ng,now()]});\n await tx.commit();return {ok:true,agent,task,generation:ng};\n }catch(e){try{await tx.rollback()}catch{};return {ok:false,agent,task,error:String((e as Error).message)}}\n}\nasync function verify(){\n const m:any=await one(sqlite,`SELECT * FROM ${P}epoch_meta WHERE id=1`);\n const es:any[]=(await sqlite.execute(`SELECT * FROM ${P}epoch_events ORDER BY local_seq`)).rows as any[];\n let prev=String(m.predecessor_head);const bad:any[]=[];\n for(const r of es){const payload=JSON.parse(String(r.payload_json));const h=await sha(canon({event_uuid:r.event_uuid,ts:r.ts,workstream:r.workstream,agent_id:r.agent_id,task_id:r.task_id,type:r.type,payload,prev_hash:r.prev_hash}));if(String(r.prev_hash)!==prev||String(r.event_hash)!==h)bad.push(r.local_seq);prev=String(r.event_hash)}\n return {ok:bad.length===0&&prev===String(m.event_head_hash)&&es.length===Number(m.new_event_count),bad,head:prev,generation:Number(m.generation),events:es.length};\n}\n\nawait reset();\nconst observations:any={};\nobservations.r0=await atomicRegister(\"A\",\"after_agent\");\nobservations.after_r0={verify:await verify(),agent:await one(sqlite,`SELECT * FROM ${P}agents WHERE id='A'`)};\nobservations.r1=await atomicRegister(\"A\",\"after_event\");\nobservations.after_r1={verify:await verify(),agent:await one(sqlite,`SELECT * FROM ${P}agents WHERE id='A'`)};\nobservations.ra=await atomicRegister(\"A\");\nobservations.rb=await atomicRegister(\"B\");\nobservations.claim_crash=await atomicClaim(\"A\",\"T2\",\"after_task\");\nobservations.after_claim_crash={verify:await verify(),task:await one(sqlite,`SELECT * FROM ${P}tasks WHERE id='T2'`),agent:await one(sqlite,`SELECT * FROM ${P}agents WHERE id='A'`)};\nobservations.claim_race=await Promise.all([atomicClaim(\"A\",\"T1\"),atomicClaim(\"B\",\"T1\")]);\nconst winner=observations.claim_race.find((x:any)=>x.ok);\nobservations.after_claim_race={verify:await verify(),task:await one(sqlite,`SELECT * FROM ${P}tasks WHERE id='T1'`)};\nobservations.commit_crash=await atomicCommit(winner.agent,\"T1\",\"after_event\");\nobservations.after_commit_crash={verify:await verify(),task:await one(sqlite,`SELECT * FROM ${P}tasks WHERE id='T1'`)};\nobservations.commit_ok=await atomicCommit(winner.agent,\"T1\");\nconst realHead=(await verify()).head;\nawait sqlite.execute({sql:`UPDATE ${P}epoch_meta SET event_head_hash='BROKEN' WHERE id=1`});\nobservations.stale_parent_register=await atomicRegister(\"C\");\nconst noC=await one(sqlite,`SELECT id FROM ${P}agents WHERE id='C'`);\nawait sqlite.execute({sql:`UPDATE ${P}epoch_meta SET event_head_hash=? WHERE id=1`,args:[realHead]});\nobservations.concurrent_register=await Promise.all([atomicRegister(\"C\"),atomicRegister(\"D\")]);\nobservations.final_verify=await verify();\nconst task1:any=await one(sqlite,`SELECT * FROM ${P}tasks WHERE id='T1'`);\nconst task2:any=await one(sqlite,`SELECT * FROM ${P}tasks WHERE id='T2'`);\nconst pass=\n !observations.r0.ok&&!observations.after_r0.agent&&observations.after_r0.verify.ok&&\n !observations.r1.ok&&!observations.after_r1.agent&&observations.after_r1.verify.ok&&\n observations.ra.ok&&observations.rb.ok&&\n !observations.claim_crash.ok&&task2.state===\"READY\"&&\n observations.claim_race.filter((x:any)=>x.ok).length===1&&\n !observations.commit_crash.ok&&observations.after_commit_crash.task.state===\"LEASED\"&&\n observations.commit_ok.ok&&task1.state===\"COMPLETE\"&&\n !observations.stale_parent_register.ok&&!noC&&\n observations.concurrent_register.filter((x:any)=>x.ok).length===2&&\n observations.final_verify.ok;\nconst receipt={schema:\"BRAIN_EPOCH3_ATOMIC_CORE_DISPOSABLE_FALSIFICATION_V1\",classification:\"NONAUTHORITY_DISPOSABLE_TEST\",tests:[\"register crash after state\",\"register crash after event\",\"claim crash after task lease\",\"same-task concurrent claim\",\"commit crash after event\",\"stale parent fail-closed\",\"concurrent distinct registers\",\"final chain\"],observations,final:{task1,task2},pass,direct_sprites_calls:0,human_authority_approval:false};\nawait blob.set(\"evidence/atomic_core_v1.json\",JSON.stringify(receipt,null,2));\nconsole.log(JSON.stringify(receipt,null,2));\n",[172],"pulls","branches","forks","envVars",{"_184":61,"_186":61},"connections",{"_184":61,"_185":61},"count","unfilledCount","emptyCount",{"_43":171,"_32":172,"_30":173,"_138":-5,"_41":42,"_40":169,"_140":149,"_38":209,"_13":61,"_33":34,"_35":175,"_24":25,"_143":-5,"_194":210,"_27":211},{"_43":167,"_32":28,"_30":31,"_138":-5,"_41":42,"_40":14,"_140":25,"_38":206,"_13":169,"_33":34,"_35":37,"_24":25,"_143":-5,"_194":207,"_27":208},{"_43":160,"_32":161,"_30":162,"_138":-5,"_41":42,"_40":163,"_140":149,"_38":203,"_13":61,"_33":34,"_35":165,"_24":25,"_143":-5,"_194":204,"_27":205},{"_43":154,"_32":155,"_30":156,"_138":-5,"_41":42,"_40":151,"_140":149,"_38":200,"_13":61,"_33":34,"_35":158,"_24":25,"_143":-5,"_194":201,"_27":202},{"_43":145,"_32":146,"_30":147,"_138":-5,"_41":42,"_40":148,"_140":149,"_38":197,"_13":151,"_33":34,"_35":152,"_24":25,"_143":-5,"_194":198,"_27":199},{"_43":135,"_32":136,"_30":137,"_138":-5,"_41":42,"_40":139,"_140":25,"_38":193,"_13":61,"_33":34,"_35":142,"_24":25,"_143":-5,"_194":195,"_27":196},["D",1788781228544],"children",[],[136],["D",1788780741746],[],[146],["D",1788780453152],[],[155],["D",1788780910131],[],[161],["D",1788781241361],[],[28],["D",1788780520060],[],[172],["D",1788780453045],["D",1789563628475],{"_98":97,"_106":102},{"_98":97,"_99":100,"_101":102,"_18":55,"_103":104,"_105":25},{"_13":87,"_32":88,"_43":42,"_89":44,"_90":-5,"_91":-5,"_92":-5,"_93":-5,"_94":-5,"_95":45,"_96":97},"ctx",{"_80":-5,"_126":250,"_251":252,"_253":254,"_255":25,"_256":25,"_257":25,"_258":149,"_259":-5,"_260":-7,"_261":-7,"_262":61,"_263":25,"_264":25,"_265":-5,"_266":25,"_267":25,"_268":25,"_269":-5},"ENV",{"_221":222,"_223":224,"_225":88,"_226":227,"_228":229,"_230":231,"_232":233,"_234":235,"_236":237,"_238":239,"_240":241,"_242":243,"_244":245,"_246":247,"_248":249},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","RENDER_GIT_COMMIT","811aa22498c9b0b5a47e8d778de579cdb990f332","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 · v9