[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_392":393,"_394":395},"routes/_app.x.$handle.$name",{"_100":99,"_32":45,"_109":90,"_27":110,"_13":14,"_111":-5,"_11":112,"_113":114,"_115":116,"_117":118,"_119":120,"_20":-5,"_121":-5,"_122":-5,"_123":25,"_124":125,"_126":25,"_127":-5,"_128":-5,"_129":130},"routes/_app.x.$handle.$name.branch.$branch.version.$version.diff",{"_11":12,"_13":14,"_15":16,"_17":-5,"_18":-5},"project",{"_43":44,"_32":45,"_38":46,"_47":-5,"_48":25,"_49":50,"_51":50,"_52":53,"_54":-5,"_18":55,"_56":57,"_58":59,"_60":-5,"_61":-5,"_62":63,"_64":65,"_66":67,"_68":69,"_70":71,"_72":-5,"_73":74,"_75":74,"_76":77,"_78":77,"_79":77,"_80":74,"_81":74,"_82":83,"_84":85,"_86":87,"_88":25},"version",28,"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","full_surface_trigger_failure_injection_v1.ts","latestPath","fileId","5b26ae8c-aab4-11f1-8e0d-1607ee4eb77e","name","fileType","script","content","import { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\nimport { dispatchBrain, verifyBrainChain } from \"./kernel_tx_candidate.ts\";\n\nconst P=\"brainvn_\";\nconst HEAD=\"d88a49daefd5520d5612c1bee960bcf7f587fc5f734a8e568b749e9bd390c1db\";\nconst semanticTables=[\"workstreams\",\"agents\",\"tasks\",\"epoch_events\",\"epoch_meta\",\"artifacts\",\"claims\"];\n\nfunction iso(deltaMs=0){return new Date(Date.now()+deltaMs).toISOString().replace(\"Z\",\"+00:00\")}\nasync function one(sql:string,args:any[]=[]){const r:any=await sqlite.execute({sql,args});return r.rows?.[0]??null}\n\nasync function resetSchema(){\n for(const t of semanticTables) await sqlite.execute(`DROP TABLE IF EXISTS ${P}${t}`);\n await sqlite.execute(\"DROP TABLE IF EXISTS fi_ctl\");\n await sqlite.execute(\"DROP TABLE IF EXISTS brain_control_plane_authority_v1\");\n await sqlite.execute(`CREATE TABLE brain_control_plane_authority_v1(id INTEGER PRIMARY KEY,epoch INTEGER,writer TEXT,source_generation INTEGER,source_head TEXT,mode TEXT,prepared_at TEXT,updated_at TEXT)`);\n await sqlite.execute({sql:`INSERT INTO brain_control_plane_authority_v1 VALUES(1,2,'val_native',1863,?,'ACTIVE',datetime('now'),datetime('now'))`,args:[HEAD]});\n await sqlite.execute(`CREATE TABLE ${P}epoch_meta(\n id INTEGER PRIMARY KEY,epoch INTEGER,predecessor_generation INTEGER,predecessor_event_count INTEGER,predecessor_head TEXT,\n 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({sql:`INSERT INTO ${P}epoch_meta VALUES(1,2,1863,1991,?,100,?,0,0,'TEST','TEST',datetime('now'))`,args:[HEAD,HEAD]});\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,agent_id TEXT,task_id TEXT,\n 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}agents(\n id TEXT PRIMARY KEY,parent_id TEXT,type TEXT,workstream TEXT,role TEXT,status TEXT,boot_generation INTEGER,last_generation INTEGER,last_seen TEXT,capabilities_json TEXT)`);\n await sqlite.execute(`CREATE TABLE ${P}tasks(\n id TEXT PRIMARY KEY,workstream TEXT,state TEXT,priority REAL,depends_json TEXT,success_condition TEXT,decision_value TEXT,context_manifest TEXT,\n lease_owner TEXT,lease_mode TEXT,lease_generation INTEGER,lease_expires_at TEXT,created_at TEXT,updated_at TEXT,result_event_id INTEGER,\n requires_json TEXT,dedupe_key TEXT,assigned_agent TEXT,delegated_by TEXT,writes_json TEXT,guards_json TEXT)`);\n await sqlite.execute(`CREATE TABLE ${P}workstreams(id TEXT PRIMARY KEY,mission TEXT,head_generation INTEGER,verified_state TEXT,updated_at TEXT)`);\n await sqlite.execute(`CREATE TABLE ${P}artifacts(sha256 TEXT PRIMARY KEY,task_id TEXT,producer_agent TEXT)`);\n await sqlite.execute(`CREATE TABLE ${P}claims(id TEXT PRIMARY KEY,workstream TEXT,status TEXT)`);\n await sqlite.execute(`INSERT INTO ${P}workstreams VALUES('global','test',100,'{}',datetime('now'))`);\n await sqlite.execute(`CREATE TABLE fi_ctl(id INTEGER PRIMARY KEY CHECK(id=1),n INTEGER NOT NULL,fail_after INTEGER)`);\n await sqlite.execute(`INSERT INTO fi_ctl VALUES(1,0,NULL)`);\n}\n\nasync function seedAgent(id=\"agent-a\",status=\"READY\"){\n await sqlite.execute({sql:`INSERT INTO ${P}agents(id,parent_id,type,workstream,role,status,boot_generation,last_generation,last_seen,capabilities_json)\n VALUES(?,NULL,'CHAT','global','tester',?,100,100,?,'[]')`,args:[id,status,iso()]});\n}\nasync function seedTask(opts:any={}){\n const id=opts.id??\"task-a\",state=opts.state??\"READY\",owner=opts.owner??null,mode=opts.mode??null,g=opts.g??null,exp=opts.exp??null;\n await sqlite.execute({sql:`INSERT INTO ${P}tasks(\n id,workstream,state,priority,depends_json,success_condition,decision_value,context_manifest,\n lease_owner,lease_mode,lease_generation,lease_expires_at,created_at,updated_at,result_event_id,\n requires_json,dedupe_key,assigned_agent,delegated_by,writes_json,guards_json)\n VALUES(?,'global',?,10,'[]','pass','value','{}',?,?,?,?,?,?,NULL,'[]',?,NULL,NULL,'[]','[]')`,\n args:[id,state,owner,mode,g,exp,iso(-1000),iso(),`test:${id}`]});\n}\n\nasync function installTriggers(){\n const ops=[\"INSERT\",\"UPDATE\",\"DELETE\"];\n for(const table of [\"workstreams\",\"agents\",\"tasks\",\"epoch_events\",\"epoch_meta\"]){\n for(const op of ops){\n const trig=`fi_${table}_${op.toLowerCase()}`;\n await sqlite.execute(`DROP TRIGGER IF EXISTS ${trig}`);\n await sqlite.execute(`CREATE TRIGGER ${trig} AFTER ${op} ON ${P}${table}\n BEGIN\n UPDATE fi_ctl SET n=n+1 WHERE id=1;\n SELECT CASE WHEN (SELECT fail_after FROM fi_ctl WHERE id=1) IS NOT NULL\n AND (SELECT n FROM fi_ctl WHERE id=1)=(SELECT fail_after FROM fi_ctl WHERE id=1)\n THEN RAISE(ABORT,'FI_AFTER_WRITE') END;\n END`);\n }\n }\n}\nasync function arm(failAfter:number|null){\n await sqlite.execute({sql:\"UPDATE fi_ctl SET n=0,fail_after=? WHERE id=1\",args:[failAfter]});\n}\nasync function count(){return Number((await one(\"SELECT n FROM fi_ctl WHERE id=1\")).n)}\n\nasync function snapshot(){\n const out:any={};\n for(const t of semanticTables){\n const r:any=await sqlite.execute(`SELECT * FROM ${P}${t} ORDER BY rowid`);\n out[t]=r.rows||[];\n }\n return JSON.stringify(out);\n}\n\ntype Case={name:string,fixture:()=>Promise,payload:()=>Promise,positive:(x:any)=>boolean};\nconst cases:Case[]=[\n {name:\"register-agent\",fixture:async()=>{},payload:async()=>({args:[\"register-agent\",\"new-agent\",\"--workstream\",\"global\",\"--role\",\"tester\",\"--type\",\"CHAT\",\"--capabilities\",\"[]\"],timeout:60}),positive:x=>x?.ok===true&&x?.created===true},\n {name:\"ensure-task\",fixture:async()=>{},payload:async()=>({args:[\"ensure-task\",\"new-task\",\"--workstream\",\"global\",\"--priority\",\"10\",\"--depends\",\"[]\",\"--requires\",\"[]\",\"--writes\",\"[]\",\"--guards\",\"[]\",\"--dedupe-key\",\"test:new-task\",\"--success\",\"pass\",\"--value\",\"value\",\"--context\",\"{}\"],timeout:60}),positive:x=>x?.ok===true&&x?.created===true},\n {name:\"claim\",fixture:async()=>{await seedAgent();await seedTask();},payload:async()=>({args:[\"claim\",\"--agent\",\"agent-a\",\"--mode\",\"INTERACTIVE\",\"--lease-seconds\",\"1800\"],timeout:60}),positive:x=>x?.ok===true&&x?.task_id===\"task-a\"},\n {name:\"renew-lease\",fixture:async()=>{await seedAgent(\"agent-a\",\"WORKING\");await seedTask({state:\"LEASED\",owner:\"agent-a\",mode:\"INTERACTIVE\",g:100,exp:iso(3600000)});},payload:async()=>({args:[\"renew-lease\",\"--agent\",\"agent-a\",\"--task\",\"task-a\",\"--seconds\",\"1200\"],timeout:60}),positive:x=>x?.ok===true&&x?.semantic_generation_unchanged===true},\n {name:\"commit\",fixture:async()=>{await seedAgent(\"agent-a\",\"WORKING\");await seedTask({state:\"LEASED\",owner:\"agent-a\",mode:\"INTERACTIVE\",g:100,exp:iso(3600000)});},payload:async()=>({args:[\"commit\",\"--agent\",\"agent-a\",\"--task\",\"task-a\",\"--state\",\"COMPLETE\",\"--expected-workstream-generation\",\"100\",\"--payload\",\"{}\"],timeout:60}),positive:x=>x?.ok===true},\n {name:\"recover-stale\",fixture:async()=>{await seedAgent(\"agent-a\",\"WORKING\");await seedTask({state:\"LEASED\",owner:\"agent-a\",mode:\"INTERACTIVE\",g:100,exp:iso(-3600000)});},payload:async()=>({args:[\"recover-stale\"],timeout:60}),positive:x=>x?.ok===true&&Array.isArray(x?.recovered)&&x.recovered.includes(\"task-a\")}\n];\n\nconst results:any[]=[];\nfor(const c of cases){\n await resetSchema(); await c.fixture(); await installTriggers(); await arm(null);\n const beforePositive=await snapshot();\n let discovery:any=null,discoveryError=\"\";\n try{discovery=await dispatchBrain(JSON.stringify(await c.payload()))}catch(e){discoveryError=e instanceof Error?e.message:String(e)}\n const writeCount=await count();\n const afterPositive=await snapshot();\n const chainPositive=await verifyBrainChain();\n const positiveOk=!discoveryError&&c.positive(discovery)&&writeCount>0&&beforePositive!==afterPositive&&chainPositive?.ok===true;\n\n const injected:any[]=[];\n for(let n=1;n<=writeCount;n++){\n await resetSchema(); await c.fixture(); await installTriggers(); await arm(n);\n const before=await snapshot();\n let threw=false,error=\"\";\n try{await dispatchBrain(JSON.stringify(await c.payload()))}catch(e){threw=true;error=e instanceof Error?e.message:String(e)}\n const after=await snapshot();\n const ctl=await one(\"SELECT n,fail_after FROM fi_ctl WHERE id=1\");\n injected.push({after_write:n,threw,error,rollback_exact:before===after,ctl_after:ctl});\n }\n results.push({\n command:c.name,\n discovered_write_count:writeCount,\n discovery_result:discovery,\n discovery_error:discoveryError,\n positive_control_ok:positiveOk,\n injected,\n all_injected_rollback_exact:injected.length===writeCount&&injected.every(x=>x.threw&&x.error.includes(\"FI_AFTER_WRITE\")&&x.rollback_exact)\n });\n}\nconst report={\n schema:\"BRAIN_FULL_SURFACE_TRIGGER_FAILURE_INJECTION_V1\",\n classification:\"NONAUTHORITY_DISPOSABLE_EXACT_CANDIDATE_TEST\",\n candidate:\"kernel_tx_candidate.ts\",\n method:\"SQLITE_AFTER_TRIGGERS_COUNT_REAL_SEMANTIC_TABLE_WRITES_AND_ABORT_ON_WRITE_N\",\n results,\n total_failure_boundaries:results.reduce((a,r)=>a+r.discovered_write_count,0),\n rollback_boundaries_passed:results.reduce((a,r)=>a+r.injected.filter((x:any)=>x.threw&&x.error.includes(\"FI_AFTER_WRITE\")&&x.rollback_exact).length,0),\n all_commands_pass:results.every(r=>r.positive_control_ok&&r.all_injected_rollback_exact),\n canonical_brain_mutation:false,\n human_authority_approval:false,\n direct_sprites_calls:0,\n observed_at:new Date().toISOString()\n};\nconsole.log(JSON.stringify(report,null,2));\n","import { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\nimport { dispatchBrain, verifyBrainChain } from \"./kernel_tx_candidate.ts\";\n\nconst P=\"brainvn_\";\nconst HEAD=\"d88a49daefd5520d5612c1bee960bcf7f587fc5f734a8e568b749e9bd390c1db\";\nconst semanticTables=[\"workstreams\",\"agents\",\"tasks\",\"epoch_events\",\"epoch_meta\",\"artifacts\",\"claims\"];\n\nfunction iso(deltaMs=0){return new Date(Date.now()+deltaMs).toISOString().replace(\"Z\",\"+00:00\")}\nasync function one(sql:string,args:any[]=[]){const r:any=await sqlite.execute({sql,args});return r.rows?.[0]??null}\n\nasync function resetSchema(){\n for(const t of semanticTables) await sqlite.execute(`DROP TABLE IF EXISTS ${P}${t}`);\n await sqlite.execute(\"DROP TABLE IF EXISTS fi_ctl\");\n await sqlite.execute(\"DROP TABLE IF EXISTS brain_control_plane_authority_v1\");\n await sqlite.execute(`CREATE TABLE brain_control_plane_authority_v1(id INTEGER PRIMARY KEY,epoch INTEGER,writer TEXT,source_generation INTEGER,source_head TEXT,mode TEXT,prepared_at TEXT,updated_at TEXT)`);\n await sqlite.execute({sql:`INSERT INTO brain_control_plane_authority_v1 VALUES(1,2,'val_native',1863,?,'ACTIVE',datetime('now'),datetime('now'))`,args:[HEAD]});\n await sqlite.execute(`CREATE TABLE ${P}epoch_meta(\n id INTEGER PRIMARY KEY,epoch INTEGER,predecessor_generation INTEGER,predecessor_event_count INTEGER,predecessor_head TEXT,\n 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({sql:`INSERT INTO ${P}epoch_meta VALUES(1,2,1863,1991,?,100,?,0,0,'TEST','TEST',datetime('now'))`,args:[HEAD,HEAD]});\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,agent_id TEXT,task_id TEXT,\n 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}agents(\n id TEXT PRIMARY KEY,parent_id TEXT,type TEXT,workstream TEXT,role TEXT,status TEXT,boot_generation INTEGER,last_generation INTEGER,last_seen TEXT,capabilities_json TEXT)`);\n await sqlite.execute(`CREATE TABLE ${P}tasks(\n id TEXT PRIMARY KEY,workstream TEXT,state TEXT,priority REAL,depends_json TEXT,success_condition TEXT,decision_value TEXT,context_manifest TEXT,\n lease_owner TEXT,lease_mode TEXT,lease_generation INTEGER,lease_expires_at TEXT,created_at TEXT,updated_at TEXT,result_event_id INTEGER,\n requires_json TEXT,dedupe_key TEXT,assigned_agent TEXT,delegated_by TEXT,writes_json TEXT,guards_json TEXT)`);\n await sqlite.execute(`CREATE TABLE ${P}workstreams(id TEXT PRIMARY KEY,mission TEXT,head_generation INTEGER,verified_state TEXT,updated_at TEXT)`);\n await sqlite.execute(`CREATE TABLE ${P}artifacts(sha256 TEXT PRIMARY KEY,task_id TEXT,producer_agent TEXT)`);\n await sqlite.execute(`CREATE TABLE ${P}claims(id TEXT PRIMARY KEY,workstream TEXT,status TEXT)`);\n await sqlite.execute(`INSERT INTO ${P}workstreams VALUES('global','test',100,'{}',datetime('now'))`);\n await sqlite.execute(`CREATE TABLE fi_ctl(id INTEGER PRIMARY KEY CHECK(id=1),n INTEGER NOT NULL,fail_after INTEGER)`);\n await sqlite.execute(`INSERT INTO fi_ctl VALUES(1,0,NULL)`);\n}\n\nasync function seedAgent(id=\"agent-a\",status=\"READY\"){\n await sqlite.execute({sql:`INSERT INTO ${P}agents(id,parent_id,type,workstream,role,status,boot_generation,last_generation,last_seen,capabilities_json)\n VALUES(?,NULL,'CHAT','global','tester',?,100,100,?,'[]')`,args:[id,status,iso()]});\n}\nasync function seedTask(opts:any={}){\n const id=opts.id??\"task-a\",state=opts.state??\"READY\",owner=opts.owner??null,mode=opts.mode??null,g=opts.g??null,exp=opts.exp??null;\n await sqlite.execute({sql:`INSERT INTO ${P}tasks(\n id,workstream,state,priority,depends_json,success_condition,decision_value,context_manifest,\n lease_owner,lease_mode,lease_generation,lease_expires_at,created_at,updated_at,result_event_id,\n requires_json,dedupe_key,assigned_agent,delegated_by,writes_json,guards_json)\n VALUES(?,'global',?,10,'[]','pass','value','{}',?,?,?,?,?,?,NULL,'[]',?,NULL,NULL,'[]','[]')`,\n args:[id,state,owner,mode,g,exp,iso(-1000),iso(),`test:${id}`]});\n}\n\nasync function installTriggers(){\n const ops=[\"INSERT\",\"UPDATE\",\"DELETE\"];\n for(const table of [\"workstreams\",\"agents\",\"tasks\",\"epoch_events\",\"epoch_meta\"]){\n for(const op of ops){\n const trig=`fi_${table}_${op.toLowerCase()}`;\n await sqlite.execute(`DROP TRIGGER IF EXISTS ${trig}`);\n await sqlite.execute(`CREATE TRIGGER IF NOT EXISTS ${trig} AFTER ${op} ON ${P}${table}\n BEGIN\n UPDATE fi_ctl SET n=n+1 WHERE id=1;\n SELECT CASE WHEN (SELECT fail_after FROM fi_ctl WHERE id=1) IS NOT NULL\n AND (SELECT n FROM fi_ctl WHERE id=1)=(SELECT fail_after FROM fi_ctl WHERE id=1)\n THEN RAISE(ABORT,'FI_AFTER_WRITE') END;\n END`);\n }\n }\n}\nasync function arm(failAfter:number|null){\n await sqlite.execute({sql:\"UPDATE fi_ctl SET n=0,fail_after=? WHERE id=1\",args:[failAfter]});\n}\nasync function count(){return Number((await one(\"SELECT n FROM fi_ctl WHERE id=1\")).n)}\n\nasync function snapshot(){\n const out:any={};\n for(const t of semanticTables){\n const r:any=await sqlite.execute(`SELECT * FROM ${P}${t} ORDER BY rowid`);\n out[t]=r.rows||[];\n }\n return JSON.stringify(out);\n}\n\ntype Case={name:string,fixture:()=>Promise,payload:()=>Promise,positive:(x:any)=>boolean};\nconst cases:Case[]=[\n {name:\"register-agent\",fixture:async()=>{},payload:async()=>({args:[\"register-agent\",\"new-agent\",\"--workstream\",\"global\",\"--role\",\"tester\",\"--type\",\"CHAT\",\"--capabilities\",\"[]\"],timeout:60}),positive:x=>x?.ok===true&&x?.created===true},\n {name:\"ensure-task\",fixture:async()=>{},payload:async()=>({args:[\"ensure-task\",\"new-task\",\"--workstream\",\"global\",\"--priority\",\"10\",\"--depends\",\"[]\",\"--requires\",\"[]\",\"--writes\",\"[]\",\"--guards\",\"[]\",\"--dedupe-key\",\"test:new-task\",\"--success\",\"pass\",\"--value\",\"value\",\"--context\",\"{}\"],timeout:60}),positive:x=>x?.ok===true&&x?.created===true},\n {name:\"claim\",fixture:async()=>{await seedAgent();await seedTask();},payload:async()=>({args:[\"claim\",\"--agent\",\"agent-a\",\"--mode\",\"INTERACTIVE\",\"--lease-seconds\",\"1800\"],timeout:60}),positive:x=>x?.ok===true&&x?.task_id===\"task-a\"},\n {name:\"renew-lease\",fixture:async()=>{await seedAgent(\"agent-a\",\"WORKING\");await seedTask({state:\"LEASED\",owner:\"agent-a\",mode:\"INTERACTIVE\",g:100,exp:iso(3600000)});},payload:async()=>({args:[\"renew-lease\",\"--agent\",\"agent-a\",\"--task\",\"task-a\",\"--seconds\",\"1200\"],timeout:60}),positive:x=>x?.ok===true&&x?.semantic_generation_unchanged===true},\n {name:\"commit\",fixture:async()=>{await seedAgent(\"agent-a\",\"WORKING\");await seedTask({state:\"LEASED\",owner:\"agent-a\",mode:\"INTERACTIVE\",g:100,exp:iso(3600000)});},payload:async()=>({args:[\"commit\",\"--agent\",\"agent-a\",\"--task\",\"task-a\",\"--state\",\"COMPLETE\",\"--expected-workstream-generation\",\"100\",\"--payload\",\"{}\"],timeout:60}),positive:x=>x?.ok===true},\n {name:\"recover-stale\",fixture:async()=>{await seedAgent(\"agent-a\",\"WORKING\");await seedTask({state:\"LEASED\",owner:\"agent-a\",mode:\"INTERACTIVE\",g:100,exp:iso(-3600000)});},payload:async()=>({args:[\"recover-stale\"],timeout:60}),positive:x=>x?.ok===true&&Array.isArray(x?.recovered)&&x.recovered.includes(\"task-a\")}\n];\n\nconst results:any[]=[];\nfor(const c of cases){\n await resetSchema(); await c.fixture(); await installTriggers(); await arm(null);\n const beforePositive=await snapshot();\n let discovery:any=null,discoveryError=\"\";\n try{discovery=await dispatchBrain(JSON.stringify(await c.payload()))}catch(e){discoveryError=e instanceof Error?e.message:String(e)}\n const writeCount=await count();\n const afterPositive=await snapshot();\n const chainPositive=await verifyBrainChain();\n const positiveOk=!discoveryError&&c.positive(discovery)&&writeCount>0&&beforePositive!==afterPositive&&chainPositive?.ok===true;\n\n const injected:any[]=[];\n for(let n=1;n<=writeCount;n++){\n await resetSchema(); await c.fixture(); await installTriggers(); await arm(n);\n const before=await snapshot();\n let threw=false,error=\"\";\n try{await dispatchBrain(JSON.stringify(await c.payload()))}catch(e){threw=true;error=e instanceof Error?e.message:String(e)}\n const after=await snapshot();\n const ctl=await one(\"SELECT n,fail_after FROM fi_ctl WHERE id=1\");\n injected.push({after_write:n,threw,error,rollback_exact:before===after,ctl_after:ctl});\n }\n results.push({\n command:c.name,\n discovered_write_count:writeCount,\n discovery_result:discovery,\n discovery_error:discoveryError,\n positive_control_ok:positiveOk,\n injected,\n all_injected_rollback_exact:injected.length===writeCount&&injected.every(x=>x.threw&&x.error.includes(\"FI_AFTER_WRITE\")&&x.rollback_exact)\n });\n}\nconst report={\n schema:\"BRAIN_FULL_SURFACE_TRIGGER_FAILURE_INJECTION_V1\",\n classification:\"NONAUTHORITY_DISPOSABLE_EXACT_CANDIDATE_TEST\",\n candidate:\"kernel_tx_candidate.ts\",\n method:\"SQLITE_AFTER_TRIGGERS_COUNT_REAL_SEMANTIC_TABLE_WRITES_AND_ABORT_ON_WRITE_N\",\n results,\n total_failure_boundaries:results.reduce((a,r)=>a+r.discovered_write_count,0),\n rollback_boundaries_passed:results.reduce((a,r)=>a+r.injected.filter((x:any)=>x.threw&&x.error.includes(\"FI_AFTER_WRITE\")&&x.rollback_exact).length,0),\n all_commands_pass:results.every(r=>r.positive_control_ok&&r.all_injected_rollback_exact),\n canonical_brain_mutation:false,\n human_authority_approval:false,\n direct_sprites_calls:0,\n observed_at:new Date().toISOString()\n};\nconsole.log(JSON.stringify(report,null,2));\n","createdAt",["D",1788782736167],"branchVersion","branchId","7593a549-c018-4f64-abdb-1b98320d847d","id","2648bba9-6c0b-4083-b79d-cdbb12453823","brain-epoch2-atomic-q4v7",["D",1788780494642],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","Disposable epoch2 atomic-chain repair probe","imageUrl","6be0fc5c-1fef-4bd6-a1e1-67a3f8c0764e","pinnedFileId","e124f344-aab5-11f1-ad03-1607ee4eb77e","pinPreview",true,"pinMigrated","screenshotVersion","likeCount",0,"orgId","01a0715b-703f-741f-ab35-c85020e4a5e0","tursoName","2648bba96c0b4083b79dcdbb12453823","tursoHostname","2648bba96c0b4083b79dcdbb12453823-val-town.aws-us-east-2.turso.io","tursoMeasuredAt",["D",1789476648181],"pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_100":99,"_108":104},"org",{"_100":99,"_101":102,"_103":104,"_18":55,"_105":106,"_107":25},"branch",{"_13":89,"_32":90,"_43":42,"_91":44,"_92":-5,"_93":-5,"_94":-5,"_95":-5,"_96":-5,"_97":45,"_98":99},"isOwned",86,"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":387,"_47":-5,"_48":25,"_49":50,"_51":50,"_52":53,"_54":-5,"_18":55,"_56":57,"_58":59,"_60":-5,"_61":-5,"_62":63,"_64":65,"_66":67,"_68":69,"_70":388,"_72":-5,"_73":74,"_75":74,"_76":77,"_78":77,"_79":77,"_80":74,"_81":74,"_82":389,"_84":390,"_86":391,"_88":25},"tree",[292,295,296,297,298,299,300,301,302,303,304,305,306,307,308,309,310,311,312],"files",[292,293,294,295,296,297,298,299,300,301,302,303,304,305,306,307,308,309,310,311,312],"counts",{"_282":63,"_283":170,"_284":63,"_285":286,"_287":288},"contents",[131,132,133,134,135,136,137,138,139,140,141,142,143,144,145,146,147,148,149],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},{"_43":275,"_32":276,"_30":277,"_153":-5,"_41":42,"_40":278,"_155":59,"_38":279,"_13":63,"_33":280,"_35":-5,"_24":25,"_158":-5,"_27":281},{"_43":268,"_32":269,"_30":270,"_153":-5,"_41":42,"_40":271,"_155":59,"_38":272,"_13":63,"_33":34,"_35":273,"_24":25,"_158":-5,"_27":274},{"_43":261,"_32":262,"_30":263,"_153":-5,"_41":42,"_40":264,"_155":59,"_38":265,"_13":63,"_33":34,"_35":266,"_24":25,"_158":-5,"_27":267},{"_43":254,"_32":255,"_30":256,"_153":-5,"_41":42,"_40":257,"_155":59,"_38":258,"_13":63,"_33":34,"_35":259,"_24":25,"_158":-5,"_27":260},{"_43":247,"_32":248,"_30":249,"_153":-5,"_41":42,"_40":250,"_155":59,"_38":251,"_13":63,"_33":34,"_35":252,"_24":25,"_158":-5,"_27":253},{"_43":240,"_32":241,"_30":242,"_153":-5,"_41":42,"_40":243,"_155":25,"_38":244,"_13":63,"_33":34,"_35":245,"_24":25,"_158":-5,"_27":246},{"_43":233,"_32":234,"_30":235,"_153":-5,"_41":42,"_40":236,"_155":59,"_38":237,"_13":63,"_33":34,"_35":238,"_24":25,"_158":-5,"_27":239},{"_43":226,"_32":227,"_30":228,"_153":-5,"_41":42,"_40":229,"_155":59,"_38":230,"_13":63,"_33":34,"_35":231,"_24":25,"_158":-5,"_27":232},{"_43":219,"_32":220,"_30":221,"_153":-5,"_41":42,"_40":222,"_155":59,"_38":223,"_13":63,"_33":34,"_35":224,"_24":25,"_158":-5,"_27":225},{"_43":212,"_32":213,"_30":214,"_153":-5,"_41":42,"_40":215,"_155":59,"_38":216,"_13":63,"_33":34,"_35":217,"_24":25,"_158":-5,"_27":218},{"_43":209,"_32":28,"_30":31,"_153":-5,"_41":42,"_40":14,"_155":59,"_38":210,"_13":170,"_33":34,"_35":37,"_24":25,"_158":-5,"_27":211},{"_43":202,"_32":203,"_30":204,"_153":-5,"_41":42,"_40":205,"_155":59,"_38":206,"_13":63,"_33":34,"_35":207,"_24":25,"_158":-5,"_27":208},{"_43":195,"_32":196,"_30":197,"_153":-5,"_41":42,"_40":198,"_155":59,"_38":199,"_13":170,"_33":34,"_35":200,"_24":25,"_158":-5,"_27":201},{"_43":188,"_32":189,"_30":190,"_153":-5,"_41":42,"_40":191,"_155":59,"_38":192,"_13":63,"_33":34,"_35":193,"_24":25,"_158":-5,"_27":194},{"_43":181,"_32":182,"_30":183,"_153":-5,"_41":42,"_40":184,"_155":59,"_38":185,"_13":63,"_33":34,"_35":186,"_24":25,"_158":-5,"_27":187},{"_43":174,"_32":175,"_30":176,"_153":-5,"_41":42,"_40":177,"_155":59,"_38":178,"_13":63,"_33":34,"_35":179,"_24":25,"_158":-5,"_27":180},{"_43":167,"_32":168,"_30":169,"_153":-5,"_41":42,"_40":170,"_155":59,"_38":171,"_13":63,"_33":34,"_35":172,"_24":25,"_158":-5,"_27":173},{"_43":160,"_32":161,"_30":162,"_153":-5,"_41":42,"_40":163,"_155":59,"_38":164,"_13":63,"_33":34,"_35":165,"_24":25,"_158":-5,"_27":166},{"_43":150,"_32":151,"_30":152,"_153":-5,"_41":42,"_40":154,"_155":59,"_38":156,"_13":63,"_33":34,"_35":157,"_24":25,"_158":-5,"_27":159},"6c004b0e-85c6-42ab-8a51-dadb65a1d8e0","verify.ts","4343d592-aaaf-11f1-9f0d-1607ee4eb77e","parentId",3,"latest",["D",1788780514950],"import { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\nconst m:any=(await sqlite.execute(\"SELECT generation,head,event_count FROM probe_meta WHERE id=1\")).rows?.[0];\nconst es:any[]=(await sqlite.execute(\"SELECT local_seq,event_uuid,prev_hash,event_hash,generation FROM probe_events ORDER BY local_seq\")).rows as any[];\nlet prev=\"ROOT\"; const bad:any[]=[];\nfor(const e of es){ if(Number(e.local_seq)!==bad.length+1 && false){}; if(String(e.prev_hash)!==prev) bad.push({seq:e.local_seq,expected:prev,actual:e.prev_hash}); prev=String(e.event_hash); }\nconst uniqueSeq=new Set(es.map(e=>String(e.local_seq))).size===es.length;\nconst uniqueHash=new Set(es.map(e=>String(e.event_hash))).size===es.length;\nconst ok=bad.length===0&&uniqueSeq&&uniqueHash&&Number(m.event_count)===es.length&&Number(m.generation)===es.length&&String(m.head)===prev;\nconsole.log(JSON.stringify({ok,bad,events:es.length,meta:m,uniqueSeq,uniqueHash,computed_head:prev}));","label",[151],"3f9a6069-bc0b-4d9a-89e5-20b23024b1e9","val_native_kernel_epoch2_candidate.ts","cc98d310-aaaf-11f1-b686-1607ee4eb77e",5,["D",1788780745360],"import { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\nimport { blob } from \"https://esm.town/v/std/blob/main.ts\";\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\"]);\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 for(let attempt=1;attempt<=32;attempt++){\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 rs:any[]=await sqlite.batch([\n {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 {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 WHERE (SELECT event_head_hash FROM ${P}epoch_meta WHERE id=1)=?\n AND (SELECT generation FROM ${P}epoch_meta WHERE id=1)=?\n RETURNING local_seq`,\n args:[e.event_uuid,e.ts,ws,e.agent_id,e.task_id,type,canon(payload),prev,h,g,h,g]}\n ],\"write\") as any[];\n const headRows=rs?.[0]?.rows||[],eventRows=rs?.[1]?.rows||[];\n if(headRows.length===1&&eventRows.length===1)return{seq:Number(eventRows[0].local_seq),event_hash:h};\n if(headRows.length===0&&eventRows.length===0)continue;\n throw new Error(\"EVENT_APPEND_PARTIAL_CAS\");\n }\n throw new Error(\"EVENT_APPEND_CONTENTION\");\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 verifyChain(){\n const m:any=await meta(),es:any[]=(await sqlite.execute(`SELECT * FROM ${P}epoch_events ORDER BY local_seq`)).rows as any[];let prev=PREDECESSOR_HEAD,bad:any[]=[],structural_problems:any[]=[];\n for(let i=0;i[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=PREDECESSOR_EVENTS+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=PREDECESSOR_EVENTS+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=PREDECESSOR_EVENTS+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 const wtx:any=await root.transaction(\"write\");\n const m:any=(await wtx.execute(\"SELECT generation,head,event_count FROM snap_meta WHERE id=1\")).rows?.[0];\n await wtx.execute({sql:\"INSERT INTO snap_events(local_seq,event_hash,prev_hash) VALUES(1,?,?)\",args:[\"E1\",String(m.head)]});\n await wtx.execute({sql:\"UPDATE snap_meta SET generation=1,head='E1',event_count=1 WHERE id=1 AND generation=0 AND head='ROOT' AND event_count=0\"});\n await wtx.commit();\n return {committed:true};\n})();\nawait new Promise(r=>setTimeout(r,75));\nconst es:any[]=(await rtx.execute(\"SELECT local_seq,event_hash,prev_hash FROM snap_events ORDER BY local_seq\")).rows as any[];\nconst m2:any=(await rtx.execute(\"SELECT generation,head,event_count FROM snap_meta WHERE id=1\")).rows?.[0];\nawait rtx.commit();\nconst wr=await writer;\nconst mf:any=(await root.execute(\"SELECT generation,head,event_count FROM snap_meta WHERE id=1\")).rows?.[0];\nconst ef:any[]=(await root.execute(\"SELECT local_seq,event_hash,prev_hash FROM snap_events ORDER BY local_seq\")).rows as any[];\nconst oldSnapshot=Number(m1.generation)===0&&Number(m2.generation)===0&&es.length===0&&String(m2.head)===\"ROOT\";\nconst finalNew=Number(mf.generation)===1&&ef.length===1&&String(mf.head)===\"E1\";\nconsole.log(JSON.stringify({ok:oldSnapshot&&finalNew,m1,inside_events:es,m2,writer:wr,final_meta:mf,final_events:ef,oldSnapshot,finalNew}));",[175],"24449e5e-1025-4d3a-a5d5-501345c39305","quarantine_verify_probe.ts","6c6eba02-aab1-11f1-964e-1607ee4eb77e",16,["D",1788781443019],"const enc=new TextEncoder();\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(\"\")}\ntype Ev={local_seq:number,event_uuid:string,ts:string,workstream:string,agent_id:string|null,task_id:string|null,type:string,payload:any,prev_hash:string,event_hash:string,transaction_generation:number};\ntype Q={epoch:number,local_seq:number,event_uuid:string,ts:string,workstream:string,agent_id:string|null,task_id:string|null,type:string,payload:any,prev_hash:string,event_hash:string,transaction_generation:number,parent_seq:number,parent_hash:string,successor_seq:number,successor_hash:string,classification:string,manifest_sha256:string};\nasync function eventHash(e:Omit){return await sha(canon({event_uuid:e.event_uuid,ts:e.ts,workstream:e.workstream,agent_id:e.agent_id,task_id:e.task_id,type:e.type,payload:e.payload,prev_hash:e.prev_hash}))}\nasync function mk(seq:number,prev:string,type:string,payload:any):Promise{\n const e:any={event_uuid:crypto.randomUUID(),ts:new Date().toISOString(),workstream:\"global\",agent_id:null,task_id:null,type,payload,prev_hash:prev};\n return{local_seq:seq,...e,event_hash:await eventHash(e),transaction_generation:10};\n}\nfunction qBody(q:any){return{epoch:q.epoch,local_seq:q.local_seq,event_uuid:q.event_uuid,ts:q.ts,workstream:q.workstream,agent_id:q.agent_id,task_id:q.task_id,type:q.type,payload:q.payload,prev_hash:q.prev_hash,event_hash:q.event_hash,transaction_generation:q.transaction_generation,parent_seq:q.parent_seq,parent_hash:q.parent_hash,successor_seq:q.successor_seq,successor_hash:q.successor_hash,classification:q.classification}}\nasync function verify(events:Ev[],quars:Q[],meta:any,root:string){\n const es=[...events].sort((a,b)=>a.local_seq-b.local_seq),qs=[...quars].sort((a,b)=>a.local_seq-b.local_seq),problems:any[]=[];\n const qmap=new Map(qs.map(q=>[q.local_seq,q]));\n const lineage=new Set();\n for(const e of es)if(e.type===\"EPOCH_RECOVERY_QUARANTINE_COMMITTED\"&&typeof e.payload?.quarantine_manifest_sha256===\"string\")lineage.add(e.payload.quarantine_manifest_sha256);\n let prev=root,expected=1;\n const committedHashes=new Set(es.map(e=>e.event_hash));\n for(const e of es){\n if(e.local_seqe.local_seq)):0;\n for(const q of qs)if(q.local_seq>maxSeq||!qmap.has(q.local_seq))problems.push({reason:\"ORPHAN_QUARANTINE_OUT_OF_RANGE\",seq:q.local_seq});\n if(es.length+qs.length!==maxSeq)problems.push({reason:\"ROW_PLUS_QUARANTINE_COUNT_MISMATCH\",event_rows:es.length,quarantines:qs.length,max_seq:maxSeq});\n if(Number(meta.new_event_count)!==es.length)problems.push({reason:\"META_EVENT_COUNT_MISMATCH\"});\n if(String(meta.event_head_hash)!==prev)problems.push({reason:\"META_HEAD_MISMATCH\"});\n return{ok:problems.length===0,classification:problems.length?\"INVALID\":(qs.length?\"VERIFIED_RECOVERED_WITH_EXPLICIT_QUARANTINE\":\"CLEAN_APPEND_ONLY\"),problems,head:prev,max_seq:maxSeq};\n}\n\nconst ROOT=\"ROOT\";\nconst e1=await mk(1,ROOT,\"A\",{});\nconst orphan=await mk(2,e1.event_hash,\"TASK_LEASED\",{lease:\"partial\"});\nconst e3=await mk(3,e1.event_hash,\"MAIN_SUCCESSOR\",{});\nconst q0:any={epoch:2,local_seq:2,event_uuid:orphan.event_uuid,ts:orphan.ts,workstream:orphan.workstream,agent_id:orphan.agent_id,task_id:orphan.task_id,type:orphan.type,payload:orphan.payload,prev_hash:orphan.prev_hash,event_hash:orphan.event_hash,transaction_generation:orphan.transaction_generation,parent_seq:1,parent_hash:e1.event_hash,successor_seq:3,successor_hash:e3.event_hash,classification:\"NOT_CANONICAL_COMMITTED\"};\nq0.manifest_sha256=await sha(canon(qBody(q0)));\nconst recovery=await mk(4,e3.event_hash,\"EPOCH_RECOVERY_QUARANTINE_COMMITTED\",{schema:\"RECOVERY_V1\",quarantine_manifest_sha256:q0.manifest_sha256,orphan_seq:2,orphan_hash:orphan.event_hash,parent_seq:1,parent_hash:e1.event_hash,successor_seq:3,successor_hash:e3.event_hash});\nconst meta={new_event_count:3,event_head_hash:recovery.event_hash};\n\nconst baseEvents=[e1,e3,recovery];\nconst pass=await verify(baseEvents,[q0],meta,ROOT);\nconst noRegistry=await verify(baseEvents,[],meta,ROOT);\nconst noLineageEvents=[e1,e3];\nconst noLineageMeta={new_event_count:2,event_head_hash:e3.event_hash};\nconst noLineage=await verify(noLineageEvents,[q0],noLineageMeta,ROOT);\nconst badManifestQ=structuredClone(q0);badManifestQ.manifest_sha256=\"0\".repeat(64);\nconst badManifest=await verify(baseEvents,[badManifestQ],meta,ROOT);\nconst committedOrphan=await verify([e1,orphan,e3,recovery],[q0],{new_event_count:4,event_head_hash:recovery.event_hash},ROOT);\nconst wrongSuccessorQ=structuredClone(q0);wrongSuccessorQ.successor_hash=\"f\".repeat(64);wrongSuccessorQ.manifest_sha256=await sha(canon(qBody(wrongSuccessorQ)));\nconst wrongRecovery=await mk(4,e3.event_hash,\"EPOCH_RECOVERY_QUARANTINE_COMMITTED\",{quarantine_manifest_sha256:wrongSuccessorQ.manifest_sha256});\nconst wrongSuccessor=await verify([e1,e3,wrongRecovery],[wrongSuccessorQ],{new_event_count:3,event_head_hash:wrongRecovery.event_hash},ROOT);\nconst verdict=pass.ok&&!noRegistry.ok&&!noLineage.ok&&!badManifest.ok&&!committedOrphan.ok&&!wrongSuccessor.ok;\nconsole.log(JSON.stringify({\n schema:\"BRAIN_QUARANTINE_LINEAGE_VERIFIER_PROBE_V1\",\n cases:{exact_recovery:pass,gap_without_registry:noRegistry,registry_without_lineage:noLineage,bad_manifest:badManifest,quarantined_hash_committed:committedOrphan,wrong_successor:wrongSuccessor},\n pass:verdict\n},null,2));",[182],"d50bca00-cff5-45b8-8c37-3d10fe617d7a","kernel_tx_injected_candidate_v2.ts","2980e2a8-aab4-11f1-a81b-1607ee4eb77e",17,["D",1788782619166],"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();\nlet atomicTestFailAfterWrite:number|null=null;\nlet atomicTestWriteCount=0;\nfunction sqlText(arg:any){return typeof arg===\"string\"?arg:String(arg?.sql??\"\")}\nfunction isWriteSql(arg:any){\n const q=sqlText(arg).trimStart().toUpperCase();\n return [\"INSERT\",\"UPDATE\",\"DELETE\",\"REPLACE\",\"CREATE\",\"DROP\",\"ALTER\"].some(k=>q===k||q.startsWith(k+\" \")||q.startsWith(k+\"\\n\")||q.startsWith(k+\"\\t\"));\n}\nasync function txExecuteInjected(tx:any,arg:any){\n const out=await tx.execute(arg);\n if(isWriteSql(arg)){\n atomicTestWriteCount++;\n if(atomicTestFailAfterWrite!==null&&atomicTestWriteCount===atomicTestFailAfterWrite)throw new Error(\"ATOMIC_TEST_INJECT_AFTER_WRITE_\"+atomicTestWriteCount);\n }\n return out;\n}\nexport function setAtomicTestFailureAfterWrite(n:number|null){atomicTestFailAfterWrite=n;atomicTestWriteCount=0}\nexport function getAtomicTestWriteCount(){return atomicTestWriteCount}\nconst sqlite:any={\n execute:async(...args:any[])=>{\n const tx=txContext.getStore();\n if(tx)return await txExecuteInjected(tx,args[0]);\n return await (rootSqlite as any).execute(...args);\n },\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 txExecuteInjected(tx,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=false;\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 verifyChain(){\n const m:any=await meta(),es:any[]=(await sqlite.execute(`SELECT * FROM ${P}epoch_events ORDER BY local_seq`)).rows as any[];let prev=PREDECESSOR_HEAD,bad:any[]=[],structural_problems:any[]=[];\n for(let i=0;i[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=PREDECESSOR_EVENTS+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=PREDECESSOR_EVENTS+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=PREDECESSOR_EVENTS+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\nexport {\n dispatchFull as dispatchBrain,\n brainStatusSafe as brainStatus,\n verifyBrainChainSafe as verifyBrainChain,\n verifyBrainClaimGraphSafe as verifyBrainClaimGraph,\n checkpointBrainNativeSafe as checkpointBrainNative,\n recoverBrainStaleSafe as recoverBrainStale,\n registerBrainAgentSafe as registerBrainAgent,\n claimBrainTaskSafe as claimBrainTask,\n brainGenerationSafe as brainGeneration\n};\n",[189],"307062d3-0491-4382-9aa0-4185678d79a5","kernel_tx_candidate.ts","b513d446-aab0-11f1-b560-1607ee4eb77e",15,["D",1788781290482],"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=false;\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 verifyChain(){\n const m:any=await meta(),es:any[]=(await sqlite.execute(`SELECT * FROM ${P}epoch_events ORDER BY local_seq`)).rows as any[];let prev=PREDECESSOR_HEAD,bad:any[]=[],structural_problems:any[]=[];\n for(let i=0;i[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=PREDECESSOR_EVENTS+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=PREDECESSOR_EVENTS+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=PREDECESSOR_EVENTS+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\nexport {\n dispatchFull as dispatchBrain,\n brainStatusSafe as brainStatus,\n verifyBrainChainSafe as verifyBrainChain,\n verifyBrainClaimGraphSafe as verifyBrainClaimGraph,\n checkpointBrainNativeSafe as checkpointBrainNative,\n recoverBrainStaleSafe as recoverBrainStale,\n registerBrainAgentSafe as registerBrainAgent,\n claimBrainTaskSafe as claimBrainTask,\n brainGenerationSafe as brainGeneration\n};\n",[196],"74a0947e-f6d3-40f0-9738-266e307a2492","kernel_claim_tx_test.ts","cc367cfa-aab0-11f1-a198-1607ee4eb77e",13,["D",1788781174199],"import { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\nimport { dispatchBrain, verifyBrainChain } from \"./kernel_tx_candidate.ts\";\n\nconst P=\"brainvn_\";\nconst HEAD=\"d88a49daefd5520d5612c1bee960bcf7f587fc5f734a8e568b749e9bd390c1db\";\nasync function setup(constrained:boolean){\n for(const t of [\"epoch_events\",\"epoch_meta\",\"tasks\",\"agents\",\"workstreams\",\"artifacts\",\"claims\"])await sqlite.execute(`DROP TABLE IF EXISTS ${P}${t}`);\n await sqlite.execute(`DROP TABLE IF EXISTS brain_control_plane_authority_v1`);\n await sqlite.execute(`CREATE TABLE brain_control_plane_authority_v1(id INTEGER PRIMARY KEY,epoch INTEGER,writer TEXT,source_generation INTEGER,source_head TEXT,mode TEXT,prepared_at TEXT,updated_at TEXT)`);\n await sqlite.execute({sql:`INSERT INTO brain_control_plane_authority_v1 VALUES(1,2,'val_native',1863,?,'ACTIVE',datetime('now'),datetime('now'))`,args:[HEAD]});\n await sqlite.execute(`CREATE TABLE ${P}epoch_meta(\n id INTEGER PRIMARY KEY,epoch INTEGER,predecessor_generation INTEGER,predecessor_event_count INTEGER,predecessor_head TEXT,\n 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({sql:`INSERT INTO ${P}epoch_meta VALUES(1,2,1863,1991,?,100,?,0,0,'TEST','TEST',datetime('now'))`,args:[HEAD,HEAD]});\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,agent_id TEXT,task_id TEXT,\n 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}agents(\n id TEXT PRIMARY KEY,parent_id TEXT,type TEXT,workstream TEXT,role TEXT,status TEXT,boot_generation INTEGER,last_generation INTEGER,last_seen TEXT,capabilities_json TEXT)`);\n await sqlite.execute(`CREATE TABLE ${P}tasks(\n id TEXT PRIMARY KEY,workstream TEXT,state TEXT,priority REAL,depends_json TEXT,success_condition TEXT,decision_value TEXT,context_manifest TEXT,\n lease_owner TEXT,lease_mode TEXT,lease_generation INTEGER,lease_expires_at TEXT,created_at TEXT,updated_at TEXT,result_event_id INTEGER,\n requires_json TEXT,dedupe_key TEXT,assigned_agent TEXT,delegated_by TEXT,writes_json TEXT,guards_json TEXT)`);\n await sqlite.execute(constrained?\n `CREATE TABLE ${P}workstreams(id TEXT PRIMARY KEY,mission TEXT,head_generation INTEGER CHECK(head_generation<=100),verified_state TEXT,updated_at TEXT)`:\n `CREATE TABLE ${P}workstreams(id TEXT PRIMARY KEY,mission TEXT,head_generation INTEGER,verified_state TEXT,updated_at TEXT)`);\n await sqlite.execute(`CREATE TABLE ${P}artifacts(sha256 TEXT PRIMARY KEY,task_id TEXT,producer_agent TEXT)`);\n await sqlite.execute(`CREATE TABLE ${P}claims(id TEXT PRIMARY KEY,workstream TEXT,status TEXT)`);\n await sqlite.execute(`INSERT INTO ${P}agents VALUES('agent-a',NULL,'CHAT','global','tester','READY',100,100,datetime('now'),'[]')`);\n await sqlite.execute(`INSERT INTO ${P}tasks VALUES('task-a','global','READY',10,'[]','pass','value','{}',NULL,NULL,NULL,NULL,datetime('now'),datetime('now'),NULL,'[]','task-a',NULL,NULL,'[]','[]')`);\n await sqlite.execute(`INSERT INTO ${P}workstreams VALUES('global','test',100,'{}',datetime('now'))`);\n}\nasync function snap(){\n const q=async(sql:string)=>(await sqlite.execute(sql)).rows;\n return {\n task:(await q(`SELECT state,lease_owner,lease_generation FROM ${P}tasks WHERE id='task-a'`))[0],\n agent:(await q(`SELECT status,last_generation FROM ${P}agents WHERE id='agent-a'`))[0],\n ws:(await q(`SELECT head_generation FROM ${P}workstreams WHERE id='global'`))[0],\n meta:(await q(`SELECT generation,event_head_hash,new_event_count FROM ${P}epoch_meta WHERE id=1`))[0],\n events:(await q(`SELECT local_seq,type,prev_hash,event_hash FROM ${P}epoch_events ORDER BY local_seq`))\n };\n}\nconst payload=JSON.stringify({args:[\"claim\",\"--agent\",\"agent-a\",\"--mode\",\"INTERACTIVE\",\"--lease-seconds\",\"1800\"],timeout:60});\n\nawait setup(true);\nconst before=await snap();\nlet rollbackError=\"\";\ntry{await dispatchBrain(payload)}catch(e){rollbackError=e instanceof Error?e.message:String(e)}\nconst afterRollback=await snap();\nconst rollbackPass=\n rollbackError.includes(\"CHECK constraint failed\") &&\n JSON.stringify(before)===JSON.stringify(afterRollback);\n\nawait setup(false);\nconst success=await dispatchBrain(payload);\nconst afterSuccess=await snap();\nconst chain=await verifyBrainChain();\nconst successPass=\n success?.ok===true &&\n afterSuccess.task?.state===\"LEASED\" &&\n afterSuccess.task?.lease_owner===\"agent-a\" &&\n Number(afterSuccess.meta?.generation)===101 &&\n Number(afterSuccess.meta?.new_event_count)===1 &&\n afterSuccess.events?.length===1 &&\n afterSuccess.agent?.status===\"WORKING\" &&\n Number(afterSuccess.agent?.last_generation)===101 &&\n Number(afterSuccess.ws?.head_generation)===101 &&\n chain?.ok===true;\n\nconsole.log(JSON.stringify({\n schema:\"BRAIN_FULL_COMMAND_TX_CLAIM_ROLLBACK_TEST_V1\",\n rollback:{error:rollbackError,before,after:afterRollback,pass:rollbackPass},\n success:{result:success,after:afterSuccess,chain,pass:successPass},\n pass:rollbackPass&&successPass\n},null,2));",[203],"ef19e12e-ad50-4067-bb56-fd8ea0c4aea1",["D",1788782736167],[28],"3fd7a02b-0b83-4010-adc6-516d3db223d3","full_mutator_atomicity_suite_v2.ts","5fd47c02-aab4-11f1-8e56-1607ee4eb77e",25,["D",1788782710300],"import { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\nimport { dispatchBrain, verifyBrainChain, verifyBrainClaimGraph, setAtomicTestFailureAfterWrite, getAtomicTestWriteCount } from \"./kernel_tx_injected_candidate_v2.ts\";\n\nconst P=\"brainvn_\";\nconst HEAD=\"d88a49daefd5520d5612c1bee960bcf7f587fc5f734a8e568b749e9bd390c1db\";\nconst FIXED=\"2026-09-07T00:00:00.000+00:00\";\nconst PAST=\"2000-01-01T00:00:00.000+00:00\";\nconst FUTURE=\"2999-01-01T00:00:00.000+00:00\";\n\nasync function ex(sql:string,args:any[]=[]){return await sqlite.execute({sql,args})}\nasync function reset(){\n const tables=[\n \"brain_control_plane_authority_v1\",\n P+\"claim_deps\",P+\"claims\",P+\"artifacts\",P+\"replicas\",\n P+\"task_context_history\",P+\"task_invariant_history\",\n P+\"epoch_events\",P+\"epoch_meta\",P+\"tasks\",P+\"agents\",P+\"workstreams\"\n ];\n for(const t of tables) await sqlite.execute(`DROP TABLE IF EXISTS ${t}`);\n await sqlite.execute(`CREATE TABLE brain_control_plane_authority_v1(\n id INTEGER PRIMARY KEY CHECK(id=1),epoch INTEGER NOT NULL,writer TEXT NOT NULL,\n source_generation INTEGER NOT NULL,source_head TEXT NOT NULL,mode TEXT NOT NULL,\n prepared_at TEXT NOT NULL,updated_at TEXT NOT NULL)`);\n await ex(`INSERT INTO brain_control_plane_authority_v1 VALUES(1,2,'val_native',1863,?,'ACTIVE',?,?)`,[HEAD,FIXED,FIXED]);\n\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 ex(`INSERT INTO ${P}epoch_meta VALUES(1,2,1863,1991,?,100,?,0,0,'TEST','TEST',?)`,[HEAD,HEAD,FIXED]);\n\n await sqlite.execute(`CREATE TABLE ${P}epoch_events(\n local_seq INTEGER PRIMARY KEY,\n event_uuid TEXT NOT NULL UNIQUE,\n ts TEXT NOT NULL,\n workstream TEXT NOT NULL,\n agent_id TEXT,\n task_id TEXT,\n type TEXT NOT NULL,\n payload_json TEXT NOT NULL,\n prev_hash TEXT NOT NULL,\n event_hash TEXT NOT NULL UNIQUE,\n transaction_generation INTEGER NOT NULL)`);\n\n await sqlite.execute(`CREATE TABLE ${P}workstreams(\n id TEXT PRIMARY KEY,mission TEXT NOT NULL,head_generation INTEGER NOT NULL,\n verified_state TEXT NOT NULL,updated_at TEXT NOT NULL)`);\n await ex(`INSERT INTO ${P}workstreams VALUES('global','test',100,'{}',?)`,[FIXED]);\n\n await sqlite.execute(`CREATE TABLE ${P}agents(\n id TEXT PRIMARY KEY,parent_id TEXT,type TEXT NOT NULL,workstream TEXT NOT NULL,role TEXT NOT NULL,status TEXT NOT NULL,\n boot_generation INTEGER NOT NULL,last_generation INTEGER NOT NULL,last_seen TEXT NOT NULL,capabilities_json TEXT NOT NULL)`);\n\n await sqlite.execute(`CREATE TABLE ${P}tasks(\n id TEXT PRIMARY KEY,workstream TEXT NOT NULL,state TEXT NOT NULL,priority REAL NOT NULL,depends_json TEXT NOT NULL,\n success_condition TEXT NOT NULL,decision_value TEXT NOT NULL,context_manifest TEXT NOT NULL,\n lease_owner TEXT,lease_mode TEXT,lease_generation INTEGER,lease_expires_at TEXT,\n created_at TEXT NOT NULL,updated_at TEXT NOT NULL,result_event_id INTEGER,requires_json TEXT NOT NULL,\n dedupe_key TEXT NOT NULL,assigned_agent TEXT,delegated_by TEXT,writes_json TEXT NOT NULL,guards_json TEXT NOT NULL)`);\n\n await sqlite.execute(`CREATE TABLE ${P}claims(\n id TEXT PRIMARY KEY,workstream TEXT NOT NULL,status TEXT NOT NULL,statement_json TEXT NOT NULL,\n statement_sha256 TEXT NOT NULL,evidence_json TEXT NOT NULL,created_generation INTEGER NOT NULL,\n 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(\n sha256 TEXT PRIMARY KEY,size INTEGER,logical_name TEXT,producer_agent TEXT,task_id TEXT,storage_json TEXT,created_at TEXT)`);\n await sqlite.execute(`CREATE TABLE ${P}replicas(\n id INTEGER PRIMARY KEY,generation INTEGER,provider TEXT,uri TEXT,snapshot_sha256 TEXT,event_head_hash TEXT,verified INTEGER,created_at TEXT)`);\n await sqlite.execute(`CREATE TABLE ${P}task_context_history(\n id INTEGER PRIMARY KEY,task_id TEXT NOT NULL,version INTEGER NOT NULL,old_context_json TEXT NOT NULL,\n new_context_json TEXT NOT NULL,reason TEXT NOT NULL,evidence_json TEXT NOT NULL,agent_id TEXT,\n event_id INTEGER NOT NULL,created_at TEXT NOT NULL,UNIQUE(task_id,version))`);\n await sqlite.execute(`CREATE TABLE ${P}task_invariant_history(\n id INTEGER PRIMARY KEY,task_id TEXT NOT NULL,version INTEGER NOT NULL,old_dedupe_key TEXT,new_dedupe_key TEXT,\n old_writes_json TEXT,new_writes_json TEXT,old_guards_json TEXT,new_guards_json TEXT,reason TEXT,evidence_json TEXT,\n agent_id TEXT,event_id INTEGER,created_at TEXT,old_requires_json TEXT,new_requires_json TEXT,UNIQUE(task_id,version))`);\n}\n\nasync function seedAgent(id:string,opts:any={}){\n await ex(`INSERT INTO ${P}agents(id,parent_id,type,workstream,role,status,boot_generation,last_generation,last_seen,capabilities_json)\n VALUES(?,?,?,?,?,?,?,?,?,?)`,[\n id,opts.parent??null,opts.type??\"CHAT\",\"global\",opts.role??\"tester\",opts.status??\"READY\",\n 100,100,FIXED,JSON.stringify(opts.caps??[])\n ]);\n}\nasync function seedTask(id:string,opts:any={}){\n await ex(`INSERT INTO ${P}tasks(\n id,workstream,state,priority,depends_json,success_condition,decision_value,context_manifest,\n lease_owner,lease_mode,lease_generation,lease_expires_at,created_at,updated_at,result_event_id,\n requires_json,dedupe_key,assigned_agent,delegated_by,writes_json,guards_json)\n VALUES(?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?)`,[\n id,\"global\",opts.state??\"READY\",opts.priority??10,JSON.stringify(opts.depends??[]),\"success\",\"value\",\n JSON.stringify(opts.context??{}),opts.owner??null,opts.mode??null,opts.leaseGeneration??null,opts.exp??null,\n FIXED,FIXED,opts.resultEvent??null,JSON.stringify(opts.requires??[]),opts.dedupe??id,\n opts.assigned??null,opts.delegatedBy??null,JSON.stringify(opts.writes??[]),JSON.stringify(opts.guards??[])\n ]);\n}\nasync function seedClaim(id:string,status=\"VERIFIED\"){\n await ex(`INSERT INTO ${P}claims VALUES(?,?,?,?,?,?,?,?,?,?)`,[\n id,\"global\",status,JSON.stringify({id}),\"0\".repeat(64),\"[]\",100,null,FIXED,FIXED\n ]);\n}\nasync function snap(){\n const names=[\n \"brain_control_plane_authority_v1\",P+\"workstreams\",P+\"agents\",P+\"tasks\",P+\"claims\",P+\"claim_deps\",\n P+\"artifacts\",P+\"replicas\",P+\"task_context_history\",P+\"task_invariant_history\",P+\"epoch_events\",P+\"epoch_meta\"\n ];\n const out:any={};\n for(const n of names) out[n]=(await sqlite.execute(`SELECT * FROM ${n} ORDER BY rowid`)).rows||[];\n return out;\n}\n\ntype Case={name:string,fixture:()=>Promise,payload:()=>Promise,mustChange?:boolean};\nconst cases:Case[]=[\n {name:\"register-agent\",fixture:async()=>{},payload:async()=>({args:[\"register-agent\",\"agent-new\",\"--workstream\",\"global\",\"--role\",\"tester\",\"--type\",\"CHAT\",\"--capabilities\",\"[]\"],timeout:60})},\n {name:\"ensure-task\",fixture:async()=>{},payload:async()=>({args:[\"ensure-task\",\"task-new\",\"--workstream\",\"global\",\"--priority\",\"10\",\"--depends\",\"[]\",\"--requires\",\"[]\",\"--writes\",\"[]\",\"--guards\",\"[]\",\"--dedupe-key\",\"task-new\",\"--success\",\"success\",\"--value\",\"value\",\"--context\",\"{}\"],timeout:60})},\n {name:\"delegate-task\",fixture:async()=>{await seedAgent(\"parent\");await seedAgent(\"child\",{parent:\"parent\"});},payload:async()=>({args:[\"delegate-task\",\"task-del\",\"--workstream\",\"global\",\"--parent-agent\",\"parent\",\"--child-agent\",\"child\",\"--priority\",\"10\",\"--depends\",\"[]\",\"--requires\",\"[]\",\"--writes\",\"[]\",\"--guards\",\"[]\",\"--dedupe-key\",\"task-del\",\"--success\",\"success\",\"--value\",\"value\",\"--context\",\"{}\"],timeout:60})},\n {name:\"claim\",fixture:async()=>{await seedAgent(\"agent-a\");await seedTask(\"task-a\");},payload:async()=>({args:[\"claim\",\"--agent\",\"agent-a\",\"--mode\",\"INTERACTIVE\",\"--lease-seconds\",\"1800\"],timeout:60})},\n {name:\"renew-lease\",fixture:async()=>{await seedAgent(\"agent-a\",{status:\"WORKING\"});await seedTask(\"task-a\",{state:\"LEASED\",owner:\"agent-a\",mode:\"INTERACTIVE\",leaseGeneration:100,exp:FUTURE});},payload:async()=>({args:[\"renew-lease\",\"--agent\",\"agent-a\",\"--task\",\"task-a\",\"--seconds\",\"1800\"],timeout:60})},\n {name:\"recover-stale\",fixture:async()=>{await seedAgent(\"agent-a\",{status:\"WORKING\"});await seedTask(\"task-a\",{state:\"LEASED\",owner:\"agent-a\",mode:\"INTERACTIVE\",leaseGeneration:100,exp:PAST});},payload:async()=>({args:[\"recover-stale\"],timeout:60})},\n {name:\"commit-complete\",fixture:async()=>{await seedAgent(\"agent-a\",{status:\"WORKING\"});await seedTask(\"task-a\",{state:\"LEASED\",owner:\"agent-a\",mode:\"INTERACTIVE\",leaseGeneration:100,exp:FUTURE});},payload:async()=>({args:[\"commit\",\"--agent\",\"agent-a\",\"--task\",\"task-a\",\"--expected-workstream-generation\",\"100\",\"--expected-lease-generation\",\"100\",\"--state\",\"COMPLETE\",\"--payload\",\"{}\"],timeout:60})},\n {name:\"commit-invalid-propagate\",fixture:async()=>{await seedAgent(\"agent-a\",{status:\"WORKING\"});await seedTask(\"root\",{state:\"LEASED\",owner:\"agent-a\",mode:\"INTERACTIVE\",leaseGeneration:100,exp:FUTURE});await seedTask(\"dependent\",{depends:[\"root\"]});},payload:async()=>({args:[\"commit\",\"--agent\",\"agent-a\",\"--task\",\"root\",\"--expected-workstream-generation\",\"100\",\"--expected-lease-generation\",\"100\",\"--state\",\"INVALID\",\"--payload\",\"{\\\"why\\\":\\\"test\\\"}\"],timeout:60})},\n {name:\"add-claim\",fixture:async()=>{await seedAgent(\"agent-a\");},payload:async()=>({args:[\"add-claim\",\"claim-new\",\"--workstream\",\"global\",\"--status\",\"VERIFIED\",\"--statement\",\"{\\\"k\\\":\\\"v\\\"}\",\"--evidence\",\"[]\",\"--depends\",\"[]\",\"--agent\",\"agent-a\"],timeout:60})},\n {name:\"invalidate-claim\",fixture:async()=>{await seedAgent(\"agent-a\");await seedClaim(\"claim-root\");await seedClaim(\"claim-child\");await ex(`INSERT INTO ${P}claim_deps VALUES('claim-root','claim-child')`);},payload:async()=>({args:[\"invalidate-claim\",\"claim-root\",\"--reason\",\"test\",\"--agent\",\"agent-a\"],timeout:60})},\n {name:\"supersede-task-context\",fixture:async()=>{await seedAgent(\"agent-a\");await seedTask(\"task-a\");},payload:async()=>({args:[\"supersede-task-context\",\"--task\",\"task-a\",\"--agent\",\"agent-a\",\"--expected-workstream-generation\",\"100\",\"--new-context\",\"{\\\"x\\\":1}\",\"--evidence\",\"[]\",\"--reason\",\"test\"],timeout:60})},\n {name:\"migrate-task-invariants\",fixture:async()=>{await seedAgent(\"agent-a\");await seedTask(\"task-a\",{dedupe:\"old\"});},payload:async()=>({args:[\"migrate-task-invariants\",\"--task\",\"task-a\",\"--agent\",\"agent-a\",\"--expected-workstream-generation\",\"100\",\"--dedupe-key\",\"new\",\"--writes\",\"[\\\"res:a\\\"]\",\"--guards\",\"[]\",\"--evidence\",\"[]\",\"--requires\",\"[]\",\"--reason\",\"test\"],timeout:60})},\n {name:\"reconcile-causal-blocks\",fixture:async()=>{await seedAgent(\"agent-a\");await seedTask(\"terminal\",{state:\"BLOCKED\"});await seedTask(\"dependent\",{depends:[\"terminal\"]});},payload:async()=>({args:[\"reconcile-causal-blocks\",\"--workstream\",\"global\",\"--agent\",\"agent-a\",\"--expected-workstream-generation\",\"100\"],timeout:60})}\n];\n\nconst results:any[]=[];\nfor(const c of cases){\n await reset(); await c.fixture();\n setAtomicTestFailureAfterWrite(999999);\n let discovery:any=null, discoveryError=\"\";\n try{discovery=await dispatchBrain(JSON.stringify(await c.payload()))}catch(e){discoveryError=e instanceof Error?e.message:String(e)}\n const writeCount=getAtomicTestWriteCount();\n const injected:any[]=[];\n for(let n=1;n<=writeCount;n++){\n await reset(); await c.fixture();\n const before=await snap();\n setAtomicTestFailureAfterWrite(n);\n let threw=false,error=\"\";\n try{await dispatchBrain(JSON.stringify(await c.payload()))}catch(e){threw=true;error=e instanceof Error?e.message:String(e)}\n const after=await snap();\n injected.push({after_write:n,threw,error,rollback_exact:JSON.stringify(before)===JSON.stringify(after)});\n }\n await reset(); await c.fixture();\n const beforePositive=await snap();\n setAtomicTestFailureAfterWrite(null);\n let positive:any=null, positiveError=\"\";\n try{positive=await dispatchBrain(JSON.stringify(await c.payload()))}catch(e){positiveError=e instanceof Error?e.message:String(e)}\n const afterPositive=await snap();\n const chain=await verifyBrainChain();\n const graph=await verifyBrainClaimGraph();\n const positiveChanged=JSON.stringify(beforePositive)!==JSON.stringify(afterPositive);\n const pass=\n !discoveryError && !!discovery && discovery.ok!==false &&\n writeCount>0 &&\n injected.length===writeCount &&\n injected.every(x=>x.threw&&x.rollback_exact) &&\n !positiveError && !!positive && positive.ok!==false && positiveChanged &&\n chain?.ok===true && graph?.ok===true;\n results.push({\n command:c.name,discovered_write_count:writeCount,discovery_ok:!discoveryError&&!!discovery&&discovery.ok!==false,\n discovery_error:discoveryError,injected,all_injected_rollback_exact:injected.length===writeCount&&injected.every(x=>x.threw&&x.rollback_exact),\n positive_ok:!positiveError&&!!positive&&positive.ok!==false,positive_error:positiveError,positive_changed:positiveChanged,\n chain_ok:chain?.ok===true,claim_graph_ok:graph?.ok===true,pass\n });\n}\n\n// Independent concurrency fixture: two agents race for two ready tasks.\nawait reset();\nawait seedAgent(\"agent-a\"); await seedAgent(\"agent-b\");\nawait seedTask(\"task-1\",{priority:20}); await seedTask(\"task-2\",{priority:10});\nsetAtomicTestFailureAfterWrite(null);\nconst concurrencySettled=await Promise.allSettled([\n dispatchBrain(JSON.stringify({args:[\"claim\",\"--agent\",\"agent-a\",\"--mode\",\"INTERACTIVE\",\"--lease-seconds\",\"1800\"],timeout:60})),\n dispatchBrain(JSON.stringify({args:[\"claim\",\"--agent\",\"agent-b\",\"--mode\",\"INTERACTIVE\",\"--lease-seconds\",\"1800\"],timeout:60}))\n]);\nconst leased=(await sqlite.execute(`SELECT id,lease_owner FROM ${P}tasks WHERE state='LEASED' ORDER BY id`)).rows||[];\nconst owners=new Set((leased as any[]).map((x:any)=>String(x.lease_owner)));\nconst chain2=await verifyBrainChain();\nconst concurrency={\n settled:concurrencySettled.map((x:any)=>x.status===\"fulfilled\"?{status:x.status,value:x.value}:{status:x.status,reason:String(x.reason)}),\n leased,unique_owners:[...owners].sort(),chain_ok:chain2?.ok===true,\n pass:concurrencySettled.every((x:any)=>x.status===\"fulfilled\"&&x.value?.ok===true)&&leased.length===2&&owners.size===2&&chain2?.ok===true\n};\n\nconst eventSchema=(await sqlite.execute(`SELECT sql FROM sqlite_master WHERE type='table' AND name='${P}epoch_events'`)).rows?.[0]?.sql??null;\nconst indexes=(await sqlite.execute(`PRAGMA index_list(${P}epoch_events)`)).rows||[];\nconst report={\n schema:\"BRAIN_FULL_MUTATOR_ATOMICITY_FAILURE_INJECTION_V2\",\n classification:\"NONAUTHORITY_DISPOSABLE_INDEPENDENT_TEST\",\n candidate:\"kernel_tx_injected_candidate_v2.ts\",\n command_results:results,\n total_commands:results.length,\n passed_commands:results.filter(r=>r.pass).length,\n total_failure_boundaries:results.reduce((n,r)=>n+r.discovered_write_count,0),\n rollback_boundaries_passed:results.reduce((n,r)=>n+r.injected.filter((x:any)=>x.threw&&x.rollback_exact).length,0),\n concurrency,\n constrained_event_schema:{sql:eventSchema,indexes},\n checkpoint:{classification:\"FENCED_SEPARATE_TWO_PHASE_PROTOCOL_REQUIRED\",tested_here:false},\n pass:results.every(r=>r.pass)&&concurrency.pass,\n canonical_brain_mutation:false,\n direct_sprites_calls:0,\n human_authority_approval:false,\n observed_at:new Date().toISOString()\n};\nconsole.log(JSON.stringify(report,null,2));\n",[213],"d384d0f0-0e33-4b51-96af-bc387c69a71c","authority_race_verify_a1.ts","3ea20a1c-aab0-11f1-8d68-1607ee4eb77e",11,["D",1788780936672],"import { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\nconst a:any=(await sqlite.execute(\"SELECT * FROM authority_race_auth_a1 WHERE id=1\")).rows?.[0]??null;\nconst s:any=(await sqlite.execute(\"SELECT * FROM authority_race_state_a1 WHERE id=1\")).rows?.[0]??null;\nconsole.log(JSON.stringify({authority:a,state:s,pass:!!a&&String(a.mode)===\"PREPARED\"}));\n",[220],"213644cf-b725-4efe-baab-5f849397337e","authority_race_setup_a1.ts","3bb051d8-aab0-11f1-8151-1607ee4eb77e",8,["D",1788780931741],"import { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\nawait sqlite.batch([\n {sql:\"DROP TABLE IF EXISTS authority_race_auth_a1\"},\n {sql:\"DROP TABLE IF EXISTS authority_race_state_a1\"},\n {sql:\"CREATE TABLE authority_race_auth_a1(id INTEGER PRIMARY KEY CHECK(id=1),epoch INTEGER NOT NULL,writer TEXT NOT NULL,mode TEXT NOT NULL)\"},\n {sql:\"INSERT INTO authority_race_auth_a1 VALUES(1,2,'val_native','ACTIVE')\"},\n {sql:\"CREATE TABLE authority_race_state_a1(id INTEGER PRIMARY KEY,value TEXT NOT NULL,committed_at TEXT NOT NULL)\"}\n],\"write\");\nconsole.log(JSON.stringify({ok:true}));\n",[227],"528b289c-0d7e-4be2-977b-14849f81f177","authority_mutation_race_a1.ts","3cb676b6-aab0-11f1-9fd6-1607ee4eb77e",9,["D",1788780933449],"import { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\nconst tx:any=await (sqlite as any).transaction(\"write\");\nlet verdict:any;\ntry{\n const a:any=(await tx.execute(\"SELECT epoch,writer,mode FROM authority_race_auth_a1 WHERE id=1\")).rows?.[0];\n if(!a||Number(a.epoch)!==2||String(a.writer)!==\"val_native\"||String(a.mode)!==\"ACTIVE\"){\n await tx.rollback();\n verdict={ok:false,classification:\"FENCED_BEFORE_MUTATION\",authority:a??null};\n }else{\n await tx.execute({sql:\"INSERT INTO authority_race_state_a1(id,value,committed_at) VALUES(1,'MUTATION',datetime('now')) ON CONFLICT(id) DO UPDATE SET value='MUTATION',committed_at=datetime('now')\"});\n await new Promise(r=>setTimeout(r,750));\n const a2:any=(await tx.execute(\"SELECT epoch,writer,mode FROM authority_race_auth_a1 WHERE id=1\")).rows?.[0];\n if(!a2||Number(a2.epoch)!==2||String(a2.writer)!==\"val_native\"||String(a2.mode)!==\"ACTIVE\")throw new Error(\"AUTHORITY_CHANGED_INSIDE_WRITE_TX\");\n await tx.commit();\n verdict={ok:true,classification:\"MUTATION_COMMITTED_BEFORE_FENCE\"};\n }\n}catch(e){try{await tx.rollback()}catch{};throw e}\nconsole.log(JSON.stringify(verdict));\n",[234],"90e47297-243b-495d-84ef-c282c3e23acf","authority_fence_race_a1.ts","3dc334e0-aab0-11f1-b091-1607ee4eb77e",10,["D",1788780935219],"import { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\nconst tx:any=await (sqlite as any).transaction(\"write\");\ntry{\n const u:any=await tx.execute({sql:\"UPDATE authority_race_auth_a1 SET mode='PREPARED' WHERE id=1 AND epoch=2 AND writer='val_native' AND mode='ACTIVE' RETURNING mode\"});\n await tx.commit();\n console.log(JSON.stringify({ok:true,rows:(u.rows||[]).length,classification:(u.rows||[]).length?\"FENCE_COMMITTED\":\"ALREADY_FENCED\"}));\n}catch(e){try{await tx.rollback()}catch{};throw e}\n",[241],"72612250-59c4-4e88-8f57-db39b36fed16","atomic_once.ts","422b6666-aaaf-11f1-b55f-1607ee4eb77e",2,["D",1788780513063],"import { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\nconst tx=await (sqlite as any).transaction(\"write\");\ntry{\n const mr:any=await tx.execute(\"SELECT generation,head,event_count FROM probe_meta WHERE id=1\");\n const m:any=mr.rows?.[0];\n if(!m) throw new Error(\"META_MISSING\");\n const seq=Number(m.event_count)+1;\n const event_uuid=crypto.randomUUID();\n const event_hash=event_uuid;\n const before=String(m.head);\n await tx.execute({sql:\"INSERT INTO probe_events(local_seq,event_uuid,prev_hash,event_hash,generation) VALUES(?,?,?,?,?)\",args:[seq,event_uuid,before,event_hash,Number(m.generation)]});\n await tx.execute({sql:\"UPDATE probe_tasks SET state='LEASED',last_event_hash=? WHERE id='T'\",args:[event_hash]});\n const u:any=await tx.execute({sql:\"UPDATE probe_meta SET generation=generation+1,head=?,event_count=event_count+1 WHERE id=1 AND generation=? AND head=? AND event_count=?\",args:[event_hash,Number(m.generation),before,Number(m.event_count)]});\n if(Number(u.rowsAffected??0)!==1) throw new Error(\"STALE_PARENT_CAS\");\n await tx.commit();\n console.log(JSON.stringify({ok:true,seq,prev_hash:before,event_hash}));\n}catch(e){\n try{await tx.rollback()}catch{}\n throw e;\n}",[248],"3c3f95e1-7fc9-4f29-aa0d-1779881723db","atomic_fail.ts","80703e2e-aaaf-11f1-855a-1607ee4eb77e",4,["D",1788780617427],"import { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\nconst tx=await (sqlite as any).transaction(\"write\");\nconst mr:any=await tx.execute(\"SELECT generation,head,event_count FROM probe_meta WHERE id=1\");\nconst m:any=mr.rows?.[0];\nconst seq=Number(m.event_count)+1;\nconst event_uuid=crypto.randomUUID();\nconst event_hash=event_uuid;\nawait tx.execute({sql:\"INSERT INTO probe_events(local_seq,event_uuid,prev_hash,event_hash,generation) VALUES(?,?,?,?,?)\",args:[seq,event_uuid,String(m.head),event_hash,Number(m.generation)]});\nawait tx.execute({sql:\"UPDATE probe_tasks SET state='FAILED-IN-TX',last_event_hash=? WHERE id='T'\",args:[event_hash]});\nawait tx.execute({sql:\"UPDATE probe_meta SET generation=generation+1,head=?,event_count=event_count+1 WHERE id=1 AND generation=? AND head=? AND event_count=?\",args:[event_hash,Number(m.generation),String(m.head),Number(m.event_count)]});\nthrow new Error(\"INTENTIONAL_ABORT_AFTER_ALL_SEMANTIC_WRITES_BEFORE_COMMIT\");",[255],"73091a9e-028b-4d8e-9d34-3fc53f9de3cd","als_tx_probe.ts","11fa613a-aab0-11f1-948b-1607ee4eb77e",6,["D",1788780861764],"import { sqlite as rawSqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\nimport { AsyncLocalStorage } from \"node:async_hooks\";\n\nconst als=new AsyncLocalStorage();\nconst T=\"als_tx_probe_v1\";\nconst routed:any=new Proxy(rawSqlite as any,{\n get(target:any,prop:any){\n if(prop===\"execute\"){\n return (...args:any[])=>{\n const tx=als.getStore();\n return tx?tx.execute(...args):target.execute(...args);\n };\n }\n if(prop===\"batch\"){\n return async (statements:any[],mode?:any)=>{\n const tx=als.getStore();\n if(!tx)return target.batch(statements,mode);\n const out:any[]=[];\n for(const s of statements)out.push(await tx.execute(s));\n return out;\n };\n }\n const v=target[prop];\n return typeof v===\"function\"?v.bind(target):v;\n }\n});\nasync function withTx(fn:()=>Promise):Promise{\n const tx=await (rawSqlite as any).transaction(\"write\");\n try{\n const result=await als.run(tx,fn);\n await tx.commit();\n return result;\n }catch(e){\n try{await tx.rollback()}catch{}\n throw e;\n }\n}\nasync function one(id:number){return (await routed.execute({sql:`SELECT * FROM ${T} WHERE id=?`,args:[id]})).rows?.[0]??null}\nawait rawSqlite.execute(`DROP TABLE IF EXISTS ${T}`);\nawait rawSqlite.execute(`CREATE TABLE ${T}(id INTEGER PRIMARY KEY,v INTEGER NOT NULL,note TEXT NOT NULL)`);\nawait rawSqlite.execute(`INSERT INTO ${T}(id,v,note) VALUES(1,0,'seed'),(2,0,'seed')`);\nlet rollbackCaught=false;\ntry{\n await withTx(async()=>{\n await routed.execute(`UPDATE ${T} SET v=11,note='inside' WHERE id=1`);\n const x=await one(1);\n if(Number(x.v)!==11)throw new Error(\"ROUTING_FAILED\");\n throw new Error(\"INTENTIONAL\");\n });\n}catch{rollbackCaught=true}\nconst afterRollback=await one(1);\n\nconst concurrent=await Promise.all([1,2].map(id=>withTx(async()=>{\n await routed.execute({sql:`UPDATE ${T} SET v=v+1,note=? WHERE id=?`,args:[`tx-${id}`,id]});\n await new Promise(r=>setTimeout(r,id===1?50:5));\n const x=await one(id);\n return {id,v:Number(x.v),note:String(x.note),same_context:String(x.note)===`tx-${id}`};\n})));\nconst final1=await one(1),final2=await one(2);\nconsole.log(JSON.stringify({\n schema:\"ALS_TX_ROUTING_PROBE_V1\",\n async_local_storage_type:typeof AsyncLocalStorage,\n transaction_type:typeof (rawSqlite as any).transaction,\n rollback:{caught:rollbackCaught,after:afterRollback,pass:rollbackCaught&&Number(afterRollback.v)===0&&String(afterRollback.note)===\"seed\"},\n concurrent,\n final:[final1,final2],\n pass:rollbackCaught&&Number(afterRollback.v)===0&&concurrent.every(x=>x.same_context)&&Number(final1.v)===1&&Number(final2.v)===1\n},null,2));",[262],"bf85c09d-a375-4986-a09f-28830699970b","als_atomic_context_probe.ts","371ef9bc-aab0-11f1-bdf9-1607ee4eb77e",7,["D",1788780924075],"import { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\nimport { AsyncLocalStorage } from \"node:async_hooks\";\nconst als=new AsyncLocalStorage();\nconst root:any=sqlite;\nconst db:any={\n execute:(q:any)=> (als.getStore()??root).execute(q),\n batch:async(qs:any[],mode:any=\"write\")=>{\n const tx:any=als.getStore();\n if(!tx)return root.batch(qs,mode);\n const out:any[]=[]; for(const q of qs)out.push(await tx.execute(q)); return out;\n }\n};\nawait root.execute(\"DROP TABLE IF EXISTS als_probe\");\nawait root.execute(\"CREATE TABLE als_probe(id TEXT PRIMARY KEY,ctx TEXT NOT NULL)\");\nasync function nestedWrite(id:string){\n await Promise.resolve();\n await db.execute({sql:\"INSERT INTO als_probe(id,ctx) VALUES(?,?)\",args:[id,id]});\n const rs:any[]=await db.batch([\n {sql:\"UPDATE als_probe SET ctx=ctx||'-a' WHERE id=?\",args:[id]},\n {sql:\"UPDATE als_probe SET ctx=ctx||'-b' WHERE id=?\",args:[id]}\n ],\"write\");\n return rs.length;\n}\nasync function run(id:string,shouldFail:boolean){\n const tx:any=await root.transaction(\"write\");\n return await als.run(tx,async()=>{\n try{\n const batchN=await nestedWrite(id);\n await new Promise(r=>setTimeout(r,25));\n const seen:any=(await db.execute({sql:\"SELECT ctx FROM als_probe WHERE id=?\",args:[id]})).rows?.[0]?.ctx;\n if(seen!==id+\"-a-b\")throw new Error(\"CTX_LEAK_\"+id+\"_\"+seen);\n if(shouldFail)throw new Error(\"INTENTIONAL_\"+id);\n await tx.commit(); return {id,committed:true,batchN,seen};\n }catch(e){\n try{await tx.rollback()}catch{}\n return {id,committed:false,error:e instanceof Error?e.message:String(e)};\n }\n });\n}\nconst results=await Promise.all([run(\"SUCCESS\",false),run(\"ROLLBACK\",true)]);\nconst rows:any[]=(await root.execute(\"SELECT id,ctx FROM als_probe ORDER BY id\")).rows as any[];\nconsole.log(JSON.stringify({ok:rows.length===1&&rows[0].id===\"SUCCESS\"&&rows[0].ctx===\"SUCCESS-a-b\",results,rows}));",[269],"fbfe4c4d-533d-4ce6-9a4e-e495e0ca5e0c","p0-harness-v2","01a07bc0-ba40-702d-a8a0-02e7978ec009",18,["D",1788782623298],"directory",[276],"pulls","branches","forks","envVars",{"_289":63,"_291":63},"connections",{"_289":63,"_290":63},"count","unfilledCount","emptyCount",{"_43":275,"_32":276,"_30":277,"_153":-5,"_41":42,"_40":278,"_155":59,"_38":384,"_13":63,"_33":280,"_35":-5,"_24":25,"_158":-5,"_314":385,"_27":386},{"_43":376,"_32":377,"_30":378,"_153":277,"_41":42,"_40":379,"_155":25,"_38":380,"_13":170,"_33":34,"_35":381,"_24":25,"_158":-5,"_314":382,"_27":383},{"_43":368,"_32":369,"_30":370,"_153":277,"_41":42,"_40":371,"_155":59,"_38":372,"_13":264,"_33":34,"_35":373,"_24":25,"_158":-5,"_314":374,"_27":375},{"_43":268,"_32":269,"_30":270,"_153":-5,"_41":42,"_40":271,"_155":59,"_38":365,"_13":63,"_33":34,"_35":273,"_24":25,"_158":-5,"_314":366,"_27":367},{"_43":261,"_32":262,"_30":263,"_153":-5,"_41":42,"_40":264,"_155":59,"_38":362,"_13":63,"_33":34,"_35":266,"_24":25,"_158":-5,"_314":363,"_27":364},{"_43":254,"_32":255,"_30":256,"_153":-5,"_41":42,"_40":257,"_155":59,"_38":359,"_13":63,"_33":34,"_35":259,"_24":25,"_158":-5,"_314":360,"_27":361},{"_43":247,"_32":248,"_30":249,"_153":-5,"_41":42,"_40":250,"_155":59,"_38":356,"_13":63,"_33":34,"_35":252,"_24":25,"_158":-5,"_314":357,"_27":358},{"_43":240,"_32":241,"_30":242,"_153":-5,"_41":42,"_40":243,"_155":25,"_38":353,"_13":63,"_33":34,"_35":245,"_24":25,"_158":-5,"_314":354,"_27":355},{"_43":233,"_32":234,"_30":235,"_153":-5,"_41":42,"_40":236,"_155":59,"_38":350,"_13":63,"_33":34,"_35":238,"_24":25,"_158":-5,"_314":351,"_27":352},{"_43":226,"_32":227,"_30":228,"_153":-5,"_41":42,"_40":229,"_155":59,"_38":347,"_13":63,"_33":34,"_35":231,"_24":25,"_158":-5,"_314":348,"_27":349},{"_43":219,"_32":220,"_30":221,"_153":-5,"_41":42,"_40":222,"_155":59,"_38":344,"_13":63,"_33":34,"_35":224,"_24":25,"_158":-5,"_314":345,"_27":346},{"_43":212,"_32":213,"_30":214,"_153":-5,"_41":42,"_40":215,"_155":59,"_38":341,"_13":63,"_33":34,"_35":217,"_24":25,"_158":-5,"_314":342,"_27":343},{"_43":209,"_32":28,"_30":31,"_153":-5,"_41":42,"_40":14,"_155":59,"_38":338,"_13":170,"_33":34,"_35":37,"_24":25,"_158":-5,"_314":339,"_27":340},{"_43":202,"_32":203,"_30":204,"_153":-5,"_41":42,"_40":205,"_155":59,"_38":335,"_13":63,"_33":34,"_35":207,"_24":25,"_158":-5,"_314":336,"_27":337},{"_43":195,"_32":196,"_30":197,"_153":-5,"_41":42,"_40":198,"_155":59,"_38":332,"_13":170,"_33":34,"_35":200,"_24":25,"_158":-5,"_314":333,"_27":334},{"_43":188,"_32":189,"_30":190,"_153":-5,"_41":42,"_40":191,"_155":59,"_38":329,"_13":63,"_33":34,"_35":193,"_24":25,"_158":-5,"_314":330,"_27":331},{"_43":181,"_32":182,"_30":183,"_153":-5,"_41":42,"_40":184,"_155":59,"_38":326,"_13":63,"_33":34,"_35":186,"_24":25,"_158":-5,"_314":327,"_27":328},{"_43":174,"_32":175,"_30":176,"_153":-5,"_41":42,"_40":177,"_155":59,"_38":323,"_13":63,"_33":34,"_35":179,"_24":25,"_158":-5,"_314":324,"_27":325},{"_43":167,"_32":168,"_30":169,"_153":-5,"_41":42,"_40":170,"_155":59,"_38":320,"_13":63,"_33":34,"_35":172,"_24":25,"_158":-5,"_314":321,"_27":322},{"_43":160,"_32":161,"_30":162,"_153":-5,"_41":42,"_40":163,"_155":59,"_38":317,"_13":63,"_33":34,"_35":165,"_24":25,"_158":-5,"_314":318,"_27":319},{"_43":150,"_32":151,"_30":152,"_153":-5,"_41":42,"_40":154,"_155":59,"_38":313,"_13":63,"_33":34,"_35":157,"_24":25,"_158":-5,"_314":315,"_27":316},["D",1788780514950],"children",[],[151],["D",1788780745360],[],[161],["D",1788780494851],[],[168],["D",1788781213609],[],[175],["D",1788781443019],[],[182],["D",1788782619166],[],[189],["D",1788781290482],[],[196],["D",1788781174199],[],[203],["D",1788782736167],[],[28],["D",1788782710300],[],[213],["D",1788780936672],[],[220],["D",1788780931741],[],[227],["D",1788780933449],[],[234],["D",1788780935219],[],[241],["D",1788780513063],[],[248],["D",1788780617427],[],[255],["D",1788780861764],[],[262],["D",1788780924075],[],[269],"9acce2d0-d7ae-4dcb-925d-a2db8641aa7d","val_native_kernel_atomic_core_shadow_q7n5.ts","01a07bc0-ba40-702d-a8a0-06d7ed949473",27,["D",1788782713250],"import { sqlite as rootSqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\nimport { AsyncLocalStorage } from \"node:async_hooks\";\nimport { blob } from \"https://esm.town/v/std/blob/main.ts\";\n\n/*\n NONAUTHORITY P0 ATOMIC-CORE CANDIDATE.\n Not production-routed. Essential Brain mutators execute inside one Val interactive write transaction.\n Nonessential mutators stay fenced until separately proven.\n*/\nconst brainTxContext=new AsyncLocalStorage();\nlet atomicTestFailAfterWrite:number|null=null;\nlet atomicTestWriteCount=0;\nlet atomicTestEscapedWriteCount=0;\nlet atomicTestTxEntries=0;\nlet atomicTestExecuteCalls=0;\nfunction sqlText(arg:any){return typeof arg===\"string\"?arg:String(arg?.sql??\"\")}\nfunction isWriteSql(arg:any){const q=sqlText(arg).trimStart().toUpperCase();return [\"INSERT\",\"UPDATE\",\"DELETE\",\"REPLACE\",\"CREATE\",\"DROP\",\"ALTER\"].some(k=>q===k||q.startsWith(k+\" \")||q.startsWith(k+\"\\n\")||q.startsWith(k+\"\\t\"))}\nasync function executeInjected(target:any,arg:any,insideTx:boolean){\n atomicTestExecuteCalls++;\n const write=isWriteSql(arg);\n const out=await target.execute(arg);\n if(write){\n atomicTestWriteCount++;\n if(!insideTx)atomicTestEscapedWriteCount++;\n if(atomicTestFailAfterWrite!==null&&atomicTestWriteCount===atomicTestFailAfterWrite){\n throw new Error(\"ATOMIC_TEST_INJECT_AFTER_WRITE_\"+atomicTestWriteCount+(insideTx?\"_IN_TX\":\"_ESCAPED_TX\"));\n }\n }\n return out;\n}\nexport function setAtomicTestFailureAfterWrite(n:number|null){\n atomicTestFailAfterWrite=n;\n atomicTestWriteCount=0;\n atomicTestEscapedWriteCount=0;\n atomicTestTxEntries=0;\n atomicTestExecuteCalls=0;\n}\nexport function getAtomicTestWriteCount(){return atomicTestWriteCount}\nexport function getAtomicTestDiagnostics(){return {tx_entries:atomicTestTxEntries,tx_execute_calls:atomicTestExecuteCalls,write_count:atomicTestWriteCount,escaped_write_count:atomicTestEscapedWriteCount}}\nconst sqlite:any={\n execute:async (...args:any[])=>{\n const tx:any=brainTxContext.getStore();\n return tx ? await executeInjected(tx,args[0],true) : await executeInjected(rootSqlite,args[0],false);\n },\n batch:async (statements:any[],mode?:any)=>{\n const tx:any=brainTxContext.getStore();\n const out:any[]=[];\n if(!tx){\n for(const st of statements)out.push(await executeInjected(rootSqlite,st,false));\n return out;\n }\n for(const st of statements)out.push(await executeInjected(tx,st,true));\n return out;\n }\n};\nasync function withBrainWriteTransaction(fn:()=>Promise):Promise{\n const tx:any=await rootSqlite.transaction(\"write\");\n atomicTestTxEntries++;\n try{\n const value:T=await brainTxContext.run(tx,fn);\n await tx.commit();\n return value;\n }catch(e){\n try{await tx.rollback()}catch{}\n throw e;\n }\n}\n\n\nconst SRC=\"brainvn_\",P=\"atomictest_\";\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 for(let attempt=1;attempt<=32;attempt++){\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 rs:any[]=await sqlite.batch([\n {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 {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 WHERE (SELECT event_head_hash FROM ${P}epoch_meta WHERE id=1)=?\n AND (SELECT generation FROM ${P}epoch_meta WHERE id=1)=?\n RETURNING local_seq`,\n args:[e.event_uuid,e.ts,ws,e.agent_id,e.task_id,type,canon(payload),prev,h,g,h,g]}\n ],\"write\") as any[];\n const headRows=rs?.[0]?.rows||[],eventRows=rs?.[1]?.rows||[];\n if(headRows.length===1&&eventRows.length===1)return{seq:Number(eventRows[0].local_seq),event_hash:h};\n if(headRows.length===0&&eventRows.length===0)continue;\n throw new Error(\"EVENT_APPEND_PARTIAL_CAS\");\n }\n throw new Error(\"EVENT_APPEND_CONTENTION\");\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 verifyChain(){\n const m:any=await meta(),es:any[]=(await sqlite.execute(`SELECT * FROM ${P}epoch_events ORDER BY local_seq`)).rows as any[];let prev=PREDECESSOR_HEAD,bad:any[]=[],structural_problems:any[]=[];\n for(let i=0;i[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=PREDECESSOR_EVENTS+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=PREDECESSOR_EVENTS+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=PREDECESSOR_EVENTS+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)invokeFullCommand(q,cmd));\n}\n\n\nexport {\n dispatchFull as dispatchBrain,\n status as brainStatus,\n verifyChain as verifyBrainChain,\n verifyClaimGraph as verifyBrainClaimGraph,\n checkpointNative as checkpointBrainNative,\n recover as recoverBrainStale,\n register as registerBrainAgent,\n claim as claimBrainTask,\n generation as brainGeneration\n};\n",[],[276,369],"657962ea-c3dd-46f5-bf5c-9d6ed8239758","val_native_atomic_core_failure_injection_v1.ts","01a07bc0-ba41-73ef-b2b9-138269ac8659",20,["D",1788782687803],"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 { dispatchBrain, setAtomicTestFailureAfterWrite, getAtomicTestWriteCount } from \"./val_native_kernel_atomic_core_shadow_q7n5.ts\";\n\nconst P=\"atomictest_\";\nconst tables=[\"workstreams\",\"agents\",\"tasks\",\"epoch_events\",\"epoch_meta\"];\nconst enc=new TextEncoder();\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 rootSqlite.execute({sql,args});return r.rows?.[0]??null}\nasync function reset(){\n for(const t of tables)await rootSqlite.execute(`DELETE FROM ${P}${t}`);\n await rootSqlite.execute(`INSERT INTO ${P}workstreams SELECT * FROM brainvn_workstreams WHERE id='global'`);\n await rootSqlite.execute(`INSERT INTO ${P}epoch_meta SELECT * FROM brainvn_epoch_meta WHERE id=1`);\n}\nasync function snap(){\n const out:any={};\n for(const t of tables){\n const r:any=await rootSqlite.execute(`SELECT * FROM ${P}${t} ORDER BY rowid`);\n out[t]=r.rows||[];\n }\n return await sha(JSON.stringify(out));\n}\nfunction iso(deltaMs:number){return new Date(Date.now()+deltaMs).toISOString().replace(\"Z\",\"+00:00\")}\nasync function seedAgent(id=\"atomic-agent\",status=\"READY\"){\n const g=Number((await one(`SELECT generation FROM ${P}epoch_meta WHERE id=1`)).generation);\n await rootSqlite.execute({sql:`INSERT INTO ${P}agents(id,parent_id,type,workstream,role,status,boot_generation,last_generation,last_seen,capabilities_json)\n VALUES(?,NULL,'CHAT','global','atomic-test',?,?,?,?,'[]')`,args:[id,status,g,g,iso(0)]});\n return g;\n}\nasync function seedTask(opts:any={}){\n const id=opts.id||\"atomic-task\",state=opts.state||\"READY\",owner=opts.owner??null,mode=opts.mode??null,g=opts.g??null,exp=opts.exp??null,priority=opts.priority??999999999;\n await rootSqlite.execute({sql:`INSERT INTO ${P}tasks(\n id,workstream,state,priority,depends_json,success_condition,decision_value,context_manifest,\n lease_owner,lease_mode,lease_generation,lease_expires_at,created_at,updated_at,result_event_id,\n requires_json,dedupe_key,assigned_agent,delegated_by,writes_json,guards_json)\n VALUES(?,'global',?,?, '[]','atomic test','atomic test','{}',?,?,?,?,?,?,NULL,'[]',?,NULL,NULL,'[]','[]')`,\n args:[id,state,priority,owner,mode,g,exp,iso(-1000),iso(0),\"atomic:test:\"+id]});\n}\nasync function wsGeneration(){return Number((await one(`SELECT head_generation FROM ${P}workstreams WHERE id='global'`)).head_generation)}\n\ntype Case={name:string,fixture:()=>Promise,payload:()=>Promise};\nconst cases:Case[]=[\n {\n name:\"register-agent\",\n fixture:async()=>{},\n payload:async()=>({args:[\"register-agent\",\"atomic-new-agent\",\"--workstream\",\"global\",\"--role\",\"atomic-test\",\"--type\",\"CHAT\",\"--capabilities\",\"[]\"],timeout:60})\n },\n {\n name:\"ensure-task\",\n fixture:async()=>{},\n payload:async()=>({args:[\"ensure-task\",\"atomic-new-task\",\"--workstream\",\"global\",\"--priority\",\"1000000\",\"--depends\",\"[]\",\"--requires\",\"[]\",\"--writes\",\"[]\",\"--guards\",\"[]\",\"--dedupe-key\",\"atomic:test:ensure:new\",\"--success\",\"atomic success\",\"--value\",\"atomic value\",\"--context\",\"{}\"],timeout:60})\n },\n {\n name:\"claim\",\n fixture:async()=>{await seedAgent();await seedTask();},\n payload:async()=>({args:[\"claim\",\"--agent\",\"atomic-agent\",\"--mode\",\"INTERACTIVE\",\"--lease-seconds\",\"600\"],timeout:60})\n },\n {\n name:\"renew-lease\",\n fixture:async()=>{const g=await seedAgent(\"atomic-agent\",\"WORKING\");await seedTask({state:\"LEASED\",owner:\"atomic-agent\",mode:\"INTERACTIVE\",g,exp:iso(3600000)});},\n payload:async()=>({args:[\"renew-lease\",\"--agent\",\"atomic-agent\",\"--task\",\"atomic-task\",\"--seconds\",\"1200\"],timeout:60})\n },\n {\n name:\"commit\",\n fixture:async()=>{const g=await seedAgent(\"atomic-agent\",\"WORKING\");await seedTask({state:\"LEASED\",owner:\"atomic-agent\",mode:\"INTERACTIVE\",g,exp:iso(3600000)});},\n payload:async()=>({args:[\"commit\",\"--agent\",\"atomic-agent\",\"--task\",\"atomic-task\",\"--state\",\"COMPLETE\",\"--expected-workstream-generation\",String(await wsGeneration()),\"--expected-lease-generation\",String(Number((await one(`SELECT lease_generation FROM ${P}tasks WHERE id='atomic-task'`)).lease_generation)),\"--payload\",\"{}\"],timeout:60})\n },\n {\n name:\"recover-stale\",\n fixture:async()=>{const g=await seedAgent(\"atomic-agent\",\"WORKING\");await seedTask({state:\"LEASED\",owner:\"atomic-agent\",mode:\"INTERACTIVE\",g,exp:iso(-3600000)});},\n payload:async()=>({args:[\"recover-stale\"],timeout:60})\n }\n];\n\nconst results:any[]=[];\nfor(const c of cases){\n await reset();await c.fixture();\n setAtomicTestFailureAfterWrite(999999);\n const positiveDiscovery=await dispatchBrain(JSON.stringify(await c.payload()));\n const writeCount=getAtomicTestWriteCount();\n const injected:any[]=[];\n for(let n=1;n<=writeCount;n++){\n await reset();await c.fixture();\n const before=await snap();\n setAtomicTestFailureAfterWrite(n);\n let threw=false,error=\"\";\n try{await dispatchBrain(JSON.stringify(await c.payload()))}catch(e){threw=true;error=e instanceof Error?e.message:String(e)}\n const after=await snap();\n injected.push({after_write:n,threw,error,rollback_exact:before===after});\n }\n await reset();await c.fixture();\n const beforePositive=await snap();\n setAtomicTestFailureAfterWrite(null);\n let positive:any=null,positiveError=\"\";\n try{positive=await dispatchBrain(JSON.stringify(await c.payload()))}catch(e){positiveError=e instanceof Error?e.message:String(e)}\n const afterPositive=await snap();\n results.push({\n command:c.name,\n discovered_write_count:writeCount,\n discovery_result:positiveDiscovery,\n injected,\n all_injected_rollback_exact:injected.length===writeCount&&injected.every(x=>x.threw&&x.rollback_exact),\n positive_control_ok:!!positive&&positive.ok!==false&&!positiveError&&beforePositive!==afterPositive,\n positive_result:positive,\n positive_error:positiveError\n });\n}\nconst report:any={\n schema:\"BRAIN_VAL_NATIVE_ATOMIC_CORE_FAILURE_INJECTION_V1\",\n classification:\"NONAUTHORITY_DISPOSABLE_SHADOW_TEST\",\n candidate:\"val_native_kernel_atomic_core_candidate_q7n5.ts\",\n tested_commands:cases.map(x=>x.name),\n results,\n total_failure_boundaries:results.reduce((n,r)=>n+r.discovered_write_count,0),\n rollback_boundaries_passed:results.reduce((n,r)=>n+r.injected.filter((x:any)=>x.threw&&x.rollback_exact).length,0),\n all_commands_pass:results.every(r=>r.all_injected_rollback_exact&&r.positive_control_ok),\n production_tables_touched:false,\n direct_sprites_calls:0,\n human_authority_approval:false,\n observed_at:new Date().toISOString()\n};\nconst body=JSON.stringify(report,null,2);\nreport.sha256=await sha(body);\nawait blob.set(\"evidence/control_plane/epoch2-command-atomicity-fork-repair-v1/ATOMIC_CORE_FAILURE_INJECTION_V1.json\",JSON.stringify(report,null,2));\nconsole.log(JSON.stringify(report,null,2));\n",[],[276,377],["D",1788782623298],[293,294],[276],["D",1788780494642],["D",1789476648181],{"_100":99,"_108":104},{"_100":99,"_101":102,"_103":104,"_18":55,"_105":106,"_107":25},{"_13":89,"_32":90,"_43":42,"_91":44,"_92":-5,"_93":-5,"_94":-5,"_95":-5,"_96":-5,"_97":45,"_98":99},"ctx",{"_82":-5,"_128":425,"_426":427,"_428":429,"_430":25,"_431":25,"_432":25,"_433":59,"_434":-5,"_435":-7,"_436":-7,"_437":63,"_438":25,"_439":25,"_440":-5,"_441":25,"_442":25,"_443":25,"_444":-5},"ENV",{"_396":397,"_398":399,"_400":90,"_401":402,"_403":404,"_405":406,"_407":408,"_409":410,"_411":412,"_413":414,"_415":416,"_417":418,"_419":420,"_421":422,"_423":424},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","RENDER_GIT_COMMIT","e87eb04e707cf64e7e532c8e8ec395f209e17f15","RENDER_GIT_BRANCH","POSTHOG_API_TOKEN","phc_nmoyuAkStEZuUp69rYlg1DZgrIt19Gx0Y4Hwf8tGgJP","POSTHOG_API_HOST","https://wart.val.town","WEB_API_TEMPLATE","https://{val}.web.val.run","APP_URL","https://www.val.town","MODULE_URL","https://esm.town","VANITY_WEB_API_TEMPLATE","https://{label}.val.run/","DENOLS_URL","https://lsp.val.town","NODE_ENV","production","CLOUDFLARE_TURNSTILE_SITE_KEY","0x4AAAAAACtaIZJH7s9rBMZ6","GOOGLE_CLIENT_ID","875989696899-jtsqkhlbdv5jrlsk8631p7ipjg3c6o62.apps.googleusercontent.com","STRIPE_PUBLISHABLE_KEY","pk_live_51N2zvWEpZTTLipIkVEwXrUG9AT0yeOOEYxszarZT1jpsZV58Ly6wlg3SltZpHN26CUalOBmUSY7adQRQiSkCZz2500qSXNkf8Y","API_URL","https://api.val.town",[],"preferencesKeybindings","default","preferencesTheme","light","preferencesFixers","preferencesCopilot","preferencesSelectionAi","preferencesCloseBrackets","preferencesChatPanelState","preferencesDprint","preferencesDenofmt","notificationCount","flagDenols","isBusinessOrgMember","businessOrgHandle","isBusinessOrgAdmin","isHigherTownieTier","navCollapsed","currentOrgId"]

Diff · v28