[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_238":239,"_240":241},"routes/_app.x.$handle.$name",{"_11":12,"_13":14,"_15":16,"_17":18,"_38":-7,"_124":-5,"_19":125,"_126":127,"_128":129,"_130":131,"_132":133,"_21":134,"_135":-5,"_136":-5,"_137":24,"_138":139,"_140":24,"_141":-5,"_142":-5,"_143":144},"routes/_app.x.$handle.$name.branch.$branch.history_.$",{"_11":12,"_13":14,"_15":16,"_17":18,"_19":20,"_21":22,"_23":24,"_25":26,"_27":28,"_29":24,"_30":-5},"handle","mosadek","name","brain-atomic-prod-sol1413","branchName","main","path","register_probe.ts","project",{"_32":72,"_13":14,"_36":73,"_74":-5,"_75":24,"_76":77,"_78":77,"_79":80,"_81":-5,"_30":68,"_82":-5,"_83":24,"_84":-5,"_85":-5,"_86":26,"_40":41,"_87":88,"_89":90,"_91":92,"_93":-5,"_94":95,"_96":95,"_97":98,"_99":98,"_100":98,"_101":95,"_102":95,"_53":103,"_104":105,"_106":107,"_108":24},"file",{"_63":64,"_13":18,"_65":66,"_67":24,"_71":-5},"isDirectory",false,"page",0,"history",[31],"hasNext","userId",{"_32":33,"_34":35,"_36":37,"_38":39,"_40":41,"_42":43,"_44":-5,"_45":-5,"_46":-5,"_47":-5,"_48":-5,"_49":50,"_51":52,"_53":54,"_21":55,"_56":-5,"_57":-5,"_58":-5,"_59":-5,"_60":61},"id","12c6da17-229f-4b0c-ad6f-7d8705bb469c","branchId","b36b8566-bf55-4532-9cac-d94a7ad9b63e","createdAt",["D",1788784440877],"version",6,"orgId","01a0715b-703f-741f-ab35-c85020e4a5e0","parentId","897e96ca-0a46-4b07-aba9-12fec4bb068f","incomingCommitId","aiChatMessageId","aiChatThreadId","aiChatThreadUserId","aiChatThreadTitle","source","mcp","clientLabel","ChatGPT","user",{"_32":68,"_40":41,"_11":12,"_69":70},{"_63":64,"_13":18,"_65":66,"_67":24},"pull","merge","revert","multiple","commits",[62],{"_32":33,"_34":35,"_36":37,"_38":39,"_40":41,"_42":43,"_44":-5,"_45":-5,"_46":-5,"_47":-5,"_48":-5,"_49":50,"_51":52,"_53":54,"_21":55,"_56":-5,"_57":-5,"_58":-5},"fileId","6750ab6e-aab8-11f1-b8df-1607ee4eb77e","fileType","script","deleted","6be0fc5c-1fef-4bd6-a1e1-67a3f8c0764e","avatar","https://lh3.googleusercontent.com/a/ACg8ocL1eT_LHhKSg5px3nXIO6eez79aZXef466qXKh2gak-0iwrvw=s96-c","deletedAtVersion","080e7df1-3aa9-479c-8396-bd480b415973",["D",1788784118811],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","Nonauthority isolated Brain atomicity lab","imageUrl","pinnedFileId","pinPreview","pinMigrated","screenshotVersion","likeCount","tursoName","080e7df13aa9479c8396bd480b415973","tursoHostname","080e7df13aa9479c8396bd480b415973-val-town.aws-us-east-2.turso.io","tursoMeasuredAt",["D",1789477862254],"pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm",{"_11":12,"_123":70},"org",{"_11":12,"_118":119,"_69":70,"_30":68,"_120":121,"_122":24},"branch",{"_38":109,"_13":16,"_32":35,"_110":72,"_111":-5,"_112":-5,"_113":-5,"_114":-5,"_115":-5,"_116":14,"_117":12},"isOwned",17,"projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","displayName","Mo Sadek","tier","free","canRestrictVals","profileImageUrl","adoptOrgId",{"_32":72,"_13":14,"_36":233,"_74":-5,"_75":24,"_76":77,"_78":77,"_79":80,"_81":-5,"_30":68,"_82":-5,"_83":24,"_84":-5,"_85":-5,"_86":26,"_40":41,"_87":88,"_89":90,"_91":234,"_93":-5,"_94":95,"_96":95,"_97":98,"_99":98,"_100":98,"_101":95,"_102":95,"_53":235,"_104":236,"_106":237,"_108":24},"tree",[163,164,165,166,167,168,169,170],"files",[163,164,165,166,167,168,169,170],"counts",{"_152":26,"_153":154,"_155":26,"_156":157,"_158":159},"contents",[],{"_32":145,"_34":35,"_63":64,"_13":18,"_146":147,"_65":66,"_38":26,"_42":-5,"_36":148,"_149":39,"_150":-5,"_17":151},"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},"46221dde-3529-41a0-a3b9-d3095f7ddffb","content","import { sqlite as db } from \"https://esm.town/v/std/sqlite/main.ts\";\nimport {dispatchBrain,verifyBrainChain,setAtomicTestFailureAfterWrite,setAtomicTestPrefix,getAtomicTestDiagnostics} from \"./kernel_shadow.ts\";\nconst p=\"atomicreg1413_\";setAtomicTestPrefix(p);\nfor(const t of [\"workstreams\",\"agents\",\"epoch_events\",\"epoch_meta\"])try{await db.execute(`DROP TABLE IF EXISTS ${p}${t}`)}catch{}\nawait db.execute(`CREATE TABLE ${p}workstreams(id TEXT PRIMARY KEY,mission TEXT,verified_state TEXT,head_generation INTEGER,updated_at TEXT)`);\nawait db.execute(`CREATE TABLE ${p}agents(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)`);\nawait db.execute(`CREATE TABLE ${p}epoch_events(local_seq INTEGER,event_uuid TEXT,ts TEXT,workstream TEXT,agent_id TEXT,task_id TEXT,type TEXT,payload_json TEXT,prev_hash TEXT,event_hash TEXT,transaction_generation INTEGER)`);\nawait db.execute(`CREATE TABLE ${p}epoch_meta(id INTEGER PRIMARY KEY,epoch INTEGER,predecessor_generation INTEGER,predecessor_event_count INTEGER,predecessor_head TEXT,generation INTEGER,event_head_hash TEXT,new_event_count INTEGER,recovered_count INTEGER,ordering_policy TEXT,classification TEXT,created_at TEXT)`);\nconst h=\"d88a49daefd5520d5612c1bee960bcf7f587fc5f734a8e568b749e9bd390c1db\",n=new Date().toISOString().replace(\"Z\",\"+00:00\");\nawait db.execute({sql:`INSERT INTO ${p}workstreams VALUES('global','x','{}',1864,?)`,args:[n]});\nawait db.execute({sql:`INSERT INTO ${p}epoch_meta VALUES(1,2,1863,1991,?,1864,?,0,0,'TEST','TEST',?)`,args:[h,h,n]});\nsetAtomicTestFailureAfterWrite(null);\nlet result:any,error=\"\";try{result=await dispatchBrain(JSON.stringify({args:[\"register-agent\",\"atomic-new-agent\",\"--workstream\",\"global\",\"--role\",\"atomic-test\",\"--type\",\"CHAT\",\"--capabilities\",\"[]\"],timeout:60}))}catch(e){error=e instanceof Error?e.message:String(e)}\nlet chain:any=null;try{chain=await verifyBrainChain()}catch(e){chain={ok:false,error:e instanceof Error?e.message:String(e)}}\nconst out={result,error,diag:getAtomicTestDiagnostics(),chain};\nconsole.log(JSON.stringify(out));\nexport default out;",["D",1788784440877],"branchVersion","label",[18],"pulls","branches",1,"forks","envVars",{"_160":26,"_162":26},"connections",{"_160":26,"_161":26},"count","unfilledCount","emptyCount",{"_32":225,"_13":226,"_63":227,"_42":-5,"_34":35,"_149":228,"_175":176,"_36":229,"_38":154,"_65":66,"_146":230,"_67":24,"_150":-5,"_180":231,"_17":232},{"_32":217,"_13":218,"_63":219,"_42":-5,"_34":35,"_149":220,"_175":176,"_36":221,"_38":154,"_65":66,"_146":222,"_67":24,"_150":-5,"_180":223,"_17":224},{"_32":209,"_13":210,"_63":211,"_42":-5,"_34":35,"_149":212,"_175":176,"_36":213,"_38":154,"_65":66,"_146":214,"_67":24,"_150":-5,"_180":215,"_17":216},{"_32":202,"_13":203,"_63":204,"_42":-5,"_34":35,"_149":198,"_175":176,"_36":205,"_38":26,"_65":66,"_146":206,"_67":24,"_150":-5,"_180":207,"_17":208},{"_32":193,"_13":194,"_63":195,"_42":-5,"_34":35,"_149":196,"_175":176,"_36":197,"_38":198,"_65":66,"_146":199,"_67":24,"_150":-5,"_180":200,"_17":201},{"_32":186,"_13":187,"_63":188,"_42":-5,"_34":35,"_149":109,"_175":176,"_36":189,"_38":26,"_65":66,"_146":190,"_67":24,"_150":-5,"_180":191,"_17":192},{"_32":145,"_13":18,"_63":64,"_42":-5,"_34":35,"_149":39,"_175":176,"_36":183,"_38":26,"_65":66,"_146":147,"_67":24,"_150":-5,"_180":184,"_17":185},{"_32":171,"_13":172,"_63":173,"_42":-5,"_34":35,"_149":174,"_175":176,"_36":177,"_38":178,"_65":66,"_146":179,"_67":24,"_150":-5,"_180":181,"_17":182},"b95f6421-ca27-4994-b4a1-44b5bd73fdb5","secondparty_bound_attempt_expiry_s9c7.ts","1aab84b6-aac0-11f1-a702-1607ee4eb77e",16,"latest",true,["D",1788787790835],2,"import { sqlite }\n\nconsole.log(JSON.stringify(await main())); from \"https://esm.town/v/std/sqlite/main.ts\";\nconst P=\"spx9c7_\";\nconst sleep=(ms:number)=>new Promise(r=>setTimeout(r,ms));\nasync function one(db:any,sql:string,args:any[]=[]){const r:any=await db.execute({sql,args});return r.rows?.[0]??null;}\nexport default async function main(){\n for(const t of [\"semantic\",\"receipts\",\"jobs\"])try{await sqlite.execute(`DROP TABLE IF EXISTS ${P}${t}`)}catch{}\n await sqlite.execute(`CREATE TABLE ${P}jobs(id TEXT PRIMARY KEY,state TEXT NOT NULL,lease_owner TEXT NOT NULL,lease_instance_id TEXT NOT NULL,lease_attempt_id TEXT NOT NULL,transport_lease_generation INTEGER NOT NULL,lease_expires_at TEXT NOT NULL)`);\n await sqlite.execute(`CREATE TABLE ${P}semantic(id INTEGER PRIMARY KEY,value TEXT NOT NULL)`);\n await sqlite.execute(`CREATE TABLE ${P}receipts(job_id TEXT,attempt_id TEXT,PRIMARY KEY(job_id,attempt_id))`);\n await sqlite.execute(`INSERT INTO ${P}jobs VALUES('j1','LEASED','w','i','a',1,datetime('now','+2 seconds'))`);\n const tx:any=await (sqlite as any).transaction(\"write\");let committed=false;\n try{\n const pre=await one(tx,`SELECT id,lease_expires_at,datetime('now') db_now FROM ${P}jobs WHERE id='j1' AND state='LEASED' AND lease_owner='w' AND lease_instance_id='i' AND lease_attempt_id='a' AND transport_lease_generation=1 AND lease_expires_at>datetime('now')`);\n if(!pre)throw new Error(\"PRE_GUARD_FAILED\");\n await tx.execute(`INSERT INTO ${P}semantic VALUES(1,'effect')`);\n const post=await one(tx,`SELECT id,lease_expires_at,datetime('now') db_now FROM ${P}jobs WHERE id='j1' AND state='LEASED' AND lease_owner='w' AND lease_instance_id='i' AND lease_attempt_id='a' AND transport_lease_generation=1 AND lease_expires_at>datetime('now')`);\n if(!post)throw new Error(\"POST_GUARD_FAILED\");\n await sleep(3100);\n const beforeReceipt=await one(tx,`SELECT lease_expires_at,datetime('now') db_now,(lease_expires_at>datetime('now')) still_live FROM ${P}jobs WHERE id='j1'`);\n await tx.execute(`INSERT INTO ${P}receipts VALUES('j1','a')`);\n await tx.commit();committed=true;\n const after=await one(sqlite,`SELECT lease_expires_at,datetime('now') db_now,(lease_expires_at>datetime('now')) still_live FROM ${P}jobs WHERE id='j1'`);\n const semantic=await one(sqlite,`SELECT COUNT(*) n FROM ${P}semantic`);\n const receipts=await one(sqlite,`SELECT COUNT(*) n FROM ${P}receipts`);\n const report={schema:\"BOUND_TRANSPORT_POST_GUARD_EXPIRY_PROBE_V1\",pre,post,beforeReceipt,after,committed,semantic_rows:Number(semantic.n),receipt_rows:Number(receipts.n),counterexample:Boolean(committed&&Number(beforeReceipt.still_live)===0&&Number(semantic.n)===1&&Number(receipts.n)===1),production_tables_touched:false}; console.log(JSON.stringify(report)); return report;\n }catch(e){if(!committed){try{await tx.rollback()}catch{}}throw e}\n finally{for(const t of [\"semantic\",\"receipts\",\"jobs\"])try{await sqlite.execute(`DROP TABLE IF EXISTS ${P}${t}`)}catch{}}\n}","children",[],[172],["D",1788784440877],[],[18],"225cefb5-8778-477b-95c9-62f887cfebd7","register_claim_concurrency_v1.ts","250c6ac4-aade-11f1-bde6-1607ee4eb77e",["D",1788800650591],"import { sqlite as db } from \"https://esm.town/v/std/sqlite/main.ts\";\nimport {dispatchBrain,verifyBrainChain,setAtomicTestFailureAfterWrite,setAtomicTestPrefix} from \"./kernel_shadow.ts\";\nconst PREV=\"d88a49daefd5520d5612c1bee960bcf7f587fc5f734a8e568b749e9bd390c1db\";\nconst now=()=>new Date().toISOString().replace(\"Z\",\"+00:00\");\nconst tables=[\"workstreams\",\"agents\",\"tasks\",\"epoch_events\",\"epoch_meta\"];\nasync function setup(p:string){\n setAtomicTestPrefix(p);setAtomicTestFailureAfterWrite(null);\n for(const t of tables)try{await db.execute(`DROP TABLE IF EXISTS ${p}${t}`)}catch{}\n await db.execute(`CREATE TABLE ${p}workstreams(id TEXT PRIMARY KEY,mission TEXT,verified_state TEXT,head_generation INTEGER,updated_at TEXT)`);\n await db.execute(`CREATE TABLE ${p}agents(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 db.execute(`CREATE TABLE ${p}tasks(id TEXT PRIMARY KEY,workstream TEXT,state TEXT,priority REAL,depends_json TEXT,success_condition TEXT,decision_value TEXT,context_manifest TEXT,lease_owner TEXT,lease_mode TEXT,lease_generation INTEGER,lease_expires_at TEXT,created_at TEXT,updated_at TEXT,result_event_id INTEGER,requires_json TEXT,dedupe_key TEXT,assigned_agent TEXT,delegated_by TEXT,writes_json TEXT,guards_json TEXT)`);\n await db.execute(`CREATE TABLE ${p}epoch_events(local_seq INTEGER,event_uuid TEXT,ts TEXT,workstream TEXT,agent_id TEXT,task_id TEXT,type TEXT,payload_json TEXT,prev_hash TEXT,event_hash TEXT,transaction_generation INTEGER)`);\n await db.execute(`CREATE TABLE ${p}epoch_meta(id INTEGER PRIMARY KEY,epoch INTEGER,predecessor_generation INTEGER,predecessor_event_count INTEGER,predecessor_head TEXT,generation INTEGER,event_head_hash TEXT,new_event_count INTEGER,recovered_count INTEGER,ordering_policy TEXT,classification TEXT,created_at TEXT)`);\n await db.execute({sql:`INSERT INTO ${p}workstreams VALUES('global','x','{}',1864,?)`,args:[now()]});\n await db.execute({sql:`INSERT INTO ${p}epoch_meta VALUES(1,2,1863,1991,?,1864,?,0,0,'TEST','TEST',?)`,args:[PREV,PREV,now()]});\n await db.execute({sql:`INSERT INTO ${p}tasks VALUES('task-1','global','READY',999999999,'[]','atomic','atomic','{}',NULL,NULL,NULL,NULL,?,?,NULL,'[]','atomic:race',NULL,NULL,'[]','[]')`,args:[now(),now()]});\n}\nasync function cleanup(p:string){for(const t of tables)try{await db.execute(`DROP TABLE IF EXISTS ${p}${t}`)}catch{}}\nfunction norm(x:PromiseSettledResult){return x.status===\"fulfilled\"?{status:\"fulfilled\",value:x.value}:{status:\"rejected\",reason:x.reason instanceof Error?x.reason.message:String(x.reason)}}\nasync function once(i:number){\n const p=`atomicrc${i}_`;await setup(p);\n try{\n const reg=JSON.stringify({args:[\"register-agent\",\"race-agent\",\"--workstream\",\"global\",\"--role\",\"atomic-test\",\"--type\",\"CHAT\",\"--capabilities\",\"[]\"],timeout:60});\n const claim=JSON.stringify({args:[\"claim\",\"--agent\",\"race-agent\",\"--mode\",\"INTERACTIVE\",\"--lease-seconds\",\"600\"],timeout:60});\n const rs=await Promise.allSettled([dispatchBrain(reg),dispatchBrain(claim)]);\n const chain=await verifyBrainChain();\n const meta:any=(await db.execute(`SELECT generation,new_event_count,event_head_hash FROM ${p}epoch_meta WHERE id=1`)).rows[0];\n const agent:any=(await db.execute(`SELECT id,status,last_generation FROM ${p}agents WHERE id='race-agent'`)).rows?.[0]??null;\n const task:any=(await db.execute(`SELECT id,state,lease_owner,lease_generation FROM ${p}tasks WHERE id='task-1'`)).rows?.[0]??null;\n const claimResult=rs[1].status===\"fulfilled\"?(rs[1] as PromiseFulfilledResult).value:null;\n const claimSucceeded=claimResult?.ok===true;\n const claimFailedBeforeRegister=rs[1].status===\"rejected\"&&String((rs[1] as PromiseRejectedResult).reason?.message??(rs[1] as PromiseRejectedResult).reason).includes(\"UNKNOWN_AGENT\");\n const expectedEvents=claimSucceeded?2:1;\n const expectedGen=1864+expectedEvents;\n const coherent=!!agent&&chain.ok&&Number(meta.new_event_count)===expectedEvents&&Number(meta.generation)===expectedGen&&\n (claimSucceeded?(task.state===\"LEASED\"&&task.lease_owner===\"race-agent\"):(claimFailedBeforeRegister&&task.state===\"READY\"&&task.lease_owner===null));\n return{i,results:rs.map(norm),claim_succeeded:claimSucceeded,claim_linearized_before_register:claimFailedBeforeRegister,meta,agent,task,chain_ok:chain.ok,pass:coherent};\n }finally{await cleanup(p)}\n}\nconst runs=[];for(let i=0;i<50;i++)runs.push(await once(i));\nconst out={schema:\"BRAIN_VAL_NATIVE_CONCURRENT_REGISTER_PLUS_CLAIM_LINEARIZATION_V1\",classification:\"NONAUTHORITY_ISOLATED_LAB_EVIDENCE\",lab:\"mosadek/brain-atomic-prod-sol1413\",iterations:runs.length,passes:runs.filter(x=>x.pass).length,claim_successes:runs.filter(x=>x.claim_succeeded).length,claim_pre_register_failures:runs.filter(x=>x.claim_linearized_before_register).length,pass:runs.every(x=>x.pass),runs,canonical_brain_mutation:false,authority_mutation:false,direct_sprites_calls:0,human_authority_approval:false};\nconsole.log(JSON.stringify(out));export default out;",[],[187],"c4135739-5c39-4058-a324-5e2558c87278","positive_probe.ts","8a6f2bfc-aab8-11f1-baf1-1607ee4eb77e",11,["D",1788784529552],4,"import { sqlite as db } from \"https://esm.town/v/std/sqlite/main.ts\";\nimport {dispatchBrain,verifyBrainChain,setAtomicTestFailureAfterWrite,setAtomicTestPrefix,getAtomicTestDiagnostics} from \"./kernel_shadow.ts\";\nconst cmd=\"recover-stale\";\nconst p=\"atomicpos1413_\";setAtomicTestPrefix(p);\nconst now=()=>new Date().toISOString().replace(\"Z\",\"+00:00\"), iso=(d:number)=>new Date(Date.now()+d).toISOString().replace(\"Z\",\"+00:00\");\nfor(const t of [\"workstreams\",\"agents\",\"tasks\",\"epoch_events\",\"epoch_meta\"])try{await db.execute(`DROP TABLE IF EXISTS ${p}${t}`)}catch{}\nawait db.execute(`CREATE TABLE ${p}workstreams(id TEXT PRIMARY KEY,mission TEXT,verified_state TEXT,head_generation INTEGER,updated_at TEXT)`);\nawait db.execute(`CREATE TABLE ${p}agents(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)`);\nawait db.execute(`CREATE TABLE ${p}tasks(id TEXT PRIMARY KEY,workstream TEXT,state TEXT,priority REAL,depends_json TEXT,success_condition TEXT,decision_value TEXT,context_manifest TEXT,lease_owner TEXT,lease_mode TEXT,lease_generation INTEGER,lease_expires_at TEXT,created_at TEXT,updated_at TEXT,result_event_id INTEGER,requires_json TEXT,dedupe_key TEXT,assigned_agent TEXT,delegated_by TEXT,writes_json TEXT,guards_json TEXT)`);\nawait db.execute(`CREATE TABLE ${p}epoch_events(local_seq INTEGER,event_uuid TEXT,ts TEXT,workstream TEXT,agent_id TEXT,task_id TEXT,type TEXT,payload_json TEXT,prev_hash TEXT,event_hash TEXT,transaction_generation INTEGER)`);\nawait db.execute(`CREATE TABLE ${p}epoch_meta(id INTEGER PRIMARY KEY,epoch INTEGER,predecessor_generation INTEGER,predecessor_event_count INTEGER,predecessor_head TEXT,generation INTEGER,event_head_hash TEXT,new_event_count INTEGER,recovered_count INTEGER,ordering_policy TEXT,classification TEXT,created_at TEXT)`);\nconst h=\"d88a49daefd5520d5612c1bee960bcf7f587fc5f734a8e568b749e9bd390c1db\";\nawait db.execute({sql:`INSERT INTO ${p}workstreams VALUES('global','x','{}',1864,?)`,args:[now()]});\nawait db.execute({sql:`INSERT INTO ${p}epoch_meta VALUES(1,2,1863,1991,?,1864,?,0,0,'TEST','TEST',?)`,args:[h,h,now()]});\nasync function seedAgent(id=\"atomic-agent\",status=\"READY\"){await db.execute({sql:`INSERT INTO ${p}agents VALUES(?,NULL,'CHAT','global','atomic-test',?,1864,1864,?,'[]')`,args:[id,status,now()]})}\nasync function seedTask(state=\"READY\",owner:any=null,mode:any=null,g:any=null,exp:any=null){await db.execute({sql:`INSERT INTO ${p}tasks VALUES('atomic-task','global',?,999999999,'[]','atomic test','atomic test','{}',?,?,?,?,?,?,NULL,'[]','atomic:test:atomic-task',NULL,NULL,'[]','[]')`,args:[state,owner,mode,g,exp,iso(-1000),now()]})}\nif(cmd===\"claim\"){await seedAgent();await seedTask()}\nif(cmd===\"renew-lease\"||cmd===\"commit\"){await seedAgent(\"atomic-agent\",\"WORKING\");await seedTask(\"LEASED\",\"atomic-agent\",\"INTERACTIVE\",1864,iso(3600000))}\nif(cmd===\"recover-stale\"){await seedAgent(\"atomic-agent\",\"WORKING\");await seedTask(\"LEASED\",\"atomic-agent\",\"INTERACTIVE\",1864,iso(-3600000))}\nlet q:any;\nif(cmd===\"ensure-task\")q={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};\nelse if(cmd===\"claim\")q={args:[\"claim\",\"--agent\",\"atomic-agent\",\"--mode\",\"INTERACTIVE\",\"--lease-seconds\",\"600\"],timeout:60};\nelse if(cmd===\"renew-lease\")q={args:[\"renew-lease\",\"--agent\",\"atomic-agent\",\"--task\",\"atomic-task\",\"--seconds\",\"1200\"],timeout:60};\nelse if(cmd===\"commit\")q={args:[\"commit\",\"--agent\",\"atomic-agent\",\"--task\",\"atomic-task\",\"--state\",\"COMPLETE\",\"--expected-workstream-generation\",\"1864\",\"--expected-lease-generation\",\"1864\",\"--payload\",\"{}\"],timeout:60};\nelse if(cmd===\"recover-stale\")q={args:[\"recover-stale\"],timeout:60};\nelse q={args:[\"register-agent\",\"atomic-new-agent\",\"--workstream\",\"global\",\"--role\",\"atomic-test\",\"--type\",\"CHAT\",\"--capabilities\",\"[]\"],timeout:60};\nsetAtomicTestFailureAfterWrite(null);let result:any,error=\"\";try{result=await dispatchBrain(JSON.stringify(q))}catch(e){error=e instanceof Error?e.message:String(e)}\nlet chain:any;try{chain=await verifyBrainChain()}catch(e){chain={ok:false,error:e instanceof Error?e.message:String(e)}}\nconst out={cmd,result,error,diag:getAtomicTestDiagnostics(),chain_ok:chain?.ok,chain};\nconsole.log(JSON.stringify(out));export default out;",[],[194],"e68bbfe8-a0c5-4efd-867a-cd602483c73d","matrix.ts","ddcba33a-aab7-11f1-b868-1607ee4eb77e",["D",1788784209998],"import { sqlite as db } from \"https://esm.town/v/std/sqlite/main.ts\";\nimport {\n dispatchBrain,\n verifyBrainChain,\n setAtomicTestFailureAfterWrite,\n getAtomicTestDiagnostics,\n setAtomicTestPrefix\n} from \"./kernel_shadow.ts\";\n\nconst enc=new TextEncoder();\nasync function hash(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(\"\")}\nfunction iso(delta=0){return new Date(Date.now()+delta).toISOString().replace(\"Z\",\"+00:00\")}\nconst PREV=\"d88a49daefd5520d5612c1bee960bcf7f587fc5f734a8e568b749e9bd390c1db\";\nconst T=[\"workstreams\",\"agents\",\"tasks\",\"epoch_events\",\"epoch_meta\"];\n\nasync function setup(p:string){\n setAtomicTestPrefix(p);\n for(const t of T)try{await db.execute(`DROP TABLE IF EXISTS ${p}${t}`)}catch{}\n await db.execute(`CREATE TABLE ${p}workstreams(id TEXT PRIMARY KEY,mission TEXT,verified_state TEXT,head_generation INTEGER,updated_at TEXT)`);\n await db.execute(`CREATE TABLE ${p}agents(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 db.execute(`CREATE TABLE ${p}tasks(id TEXT PRIMARY KEY,workstream TEXT,state TEXT,priority REAL,depends_json TEXT,success_condition TEXT,decision_value TEXT,context_manifest TEXT,lease_owner TEXT,lease_mode TEXT,lease_generation INTEGER,lease_expires_at TEXT,created_at TEXT,updated_at TEXT,result_event_id INTEGER,requires_json TEXT,dedupe_key TEXT,assigned_agent TEXT,delegated_by TEXT,writes_json TEXT,guards_json TEXT)`);\n await db.execute(`CREATE TABLE ${p}epoch_events(local_seq INTEGER,event_uuid TEXT,ts TEXT,workstream TEXT,agent_id TEXT,task_id TEXT,type TEXT,payload_json TEXT,prev_hash TEXT,event_hash TEXT,transaction_generation INTEGER)`);\n await db.execute(`CREATE TABLE ${p}epoch_meta(id INTEGER PRIMARY KEY,epoch INTEGER,predecessor_generation INTEGER,predecessor_event_count INTEGER,predecessor_head TEXT,generation INTEGER,event_head_hash TEXT,new_event_count INTEGER,recovered_count INTEGER,ordering_policy TEXT,classification TEXT,created_at TEXT)`);\n await db.execute({sql:`INSERT INTO ${p}workstreams VALUES('global','atomic lab','{}',1864,?)`,args:[iso()]});\n await db.execute({sql:`INSERT INTO ${p}epoch_meta VALUES(1,2,1863,1991,?,1864,?,0,0,'TEST','NONAUTHORITY_SHADOW',?)`,args:[PREV,PREV,iso()]});\n}\nasync function cleanup(p:string){for(const t of T)try{await db.execute(`DROP TABLE IF EXISTS ${p}${t}`)}catch{}}\nasync function snap(p:string){\n const o:any={};\n for(const t of T){const r:any=await db.execute(`SELECT * FROM ${p}${t} ORDER BY rowid`);o[t]=r.rows||[]}\n return await hash(JSON.stringify(o));\n}\nasync function seedAgent(p:string,id=\"atomic-agent\",status=\"READY\"){\n const g=Number((await db.execute(`SELECT generation FROM ${p}epoch_meta WHERE id=1`)).rows[0].generation);\n await db.execute({sql:`INSERT INTO ${p}agents(id,parent_id,type,workstream,role,status,boot_generation,last_generation,last_seen,capabilities_json) VALUES(?,NULL,'CHAT','global','atomic-test',?,?,?,?,'[]')`,args:[id,status,g,g,iso()]});\n return g;\n}\nasync function seedTask(p:string,o:any={}){\n const id=o.id||\"atomic-task\";\n await db.execute({sql:`INSERT INTO ${p}tasks(id,workstream,state,priority,depends_json,success_condition,decision_value,context_manifest,lease_owner,lease_mode,lease_generation,lease_expires_at,created_at,updated_at,result_event_id,requires_json,dedupe_key,assigned_agent,delegated_by,writes_json,guards_json) VALUES(?,'global',?,?, '[]','atomic test','atomic test','{}',?,?,?,?,?,?,NULL,'[]',?,NULL,NULL,'[]','[]')`,\n args:[id,o.state||\"READY\",o.priority??999999999,o.owner??null,o.mode??null,o.g??null,o.exp??null,iso(-1000),iso(),\"atomic:test:\"+id]});\n}\nasync function fixture(p:string,cmd:string){\n if(cmd===\"claim\"){await seedAgent(p);await seedTask(p)}\n else if(cmd===\"renew-lease\"||cmd===\"commit\"){const g=await seedAgent(p,\"atomic-agent\",\"WORKING\");await seedTask(p,{state:\"LEASED\",owner:\"atomic-agent\",mode:\"INTERACTIVE\",g,exp:iso(3600000)})}\n else if(cmd===\"recover-stale\"){const g=await seedAgent(p,\"atomic-agent\",\"WORKING\");await seedTask(p,{state:\"LEASED\",owner:\"atomic-agent\",mode:\"INTERACTIVE\",g,exp:iso(-3600000)})}\n}\nasync function payload(p:string,cmd:string){\n if(cmd===\"register-agent\")return {args:[\"register-agent\",\"atomic-new-agent\",\"--workstream\",\"global\",\"--role\",\"atomic-test\",\"--type\",\"CHAT\",\"--capabilities\",\"[]\"],timeout:60};\n if(cmd===\"ensure-task\")return {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 if(cmd===\"claim\")return {args:[\"claim\",\"--agent\",\"atomic-agent\",\"--mode\",\"INTERACTIVE\",\"--lease-seconds\",\"600\"],timeout:60};\n if(cmd===\"renew-lease\")return {args:[\"renew-lease\",\"--agent\",\"atomic-agent\",\"--task\",\"atomic-task\",\"--seconds\",\"1200\"],timeout:60};\n if(cmd===\"commit\"){\n const w=Number((await db.execute(`SELECT head_generation FROM ${p}workstreams WHERE id='global'`)).rows[0].head_generation);\n const lg=Number((await db.execute(`SELECT lease_generation FROM ${p}tasks WHERE id='atomic-task'`)).rows[0].lease_generation);\n return {args:[\"commit\",\"--agent\",\"atomic-agent\",\"--task\",\"atomic-task\",\"--state\",\"COMPLETE\",\"--expected-workstream-generation\",String(w),\"--expected-lease-generation\",String(lg),\"--payload\",\"{}\"],timeout:60};\n }\n return {args:[\"recover-stale\"],timeout:60};\n}\nasync function one(cmd:string,fail:number|null,token:string){\n const p=`atomic${token}_`;await setup(p);\n try{\n await fixture(p,cmd);const before=await snap(p);setAtomicTestFailureAfterWrite(fail);\n let result:any=null,error=\"\";try{result=await dispatchBrain(JSON.stringify(await payload(p,cmd)))}catch(e){error=e instanceof Error?e.message:String(e)}\n const diagnostics=getAtomicTestDiagnostics(),after=await snap(p);\n const chain=fail===null&&!error?await verifyBrainChain():null;\n return {fail_after:fail,error,result,write_count:Number(diagnostics?.write_count||0),tx_entries:Number(diagnostics?.tx_entries||0),state_unchanged:before===after,chain_ok:chain?.ok??null,\n injected_ok:fail!==null&&error===\"ATOMIC_TEST_INJECT_AFTER_WRITE_\"+fail&&before===after,\n positive_ok:fail===null&&!error&&result?.ok!==false&&before!==after&&chain?.ok===true};\n }finally{await cleanup(p)}\n}\nconst commands=[\"register-agent\",\"ensure-task\",\"claim\",\"renew-lease\",\"commit\",\"recover-stale\"];\nconst results:any[]=[];let k=0;\nfor(const cmd of commands){\n const pos=await one(cmd,null,\"p\"+(k++).toString(36)+\"s1413\");\n const injected:any[]=[];for(let n=1;n<=pos.write_count;n++)injected.push(await one(cmd,n,\"f\"+(k++).toString(36)+\"s1413\"));\n results.push({command:cmd,write_count:pos.write_count,positive_ok:pos.positive_ok,positive_chain_ok:pos.chain_ok,\n rollback_boundaries_passed:injected.filter(x=>x.injected_ok).length,\n rollback_boundaries_total:pos.write_count,\n all_rollback_exact:pos.write_count>0&&injected.length===pos.write_count&&injected.every(x=>x.injected_ok),\n injected:injected.map(x=>({n:x.fail_after,error:x.error,write_count:x.write_count,tx_entries:x.tx_entries,state_unchanged:x.state_unchanged,injected_ok:x.injected_ok}))});\n}\nconst report={schema:\"BRAIN_VAL_NATIVE_PRODUCTION_EQUIVALENT_ATOMIC_CORE_MATRIX_V3\",classification:\"VERIFIED_NONAUTHORITY_ISOLATED_LAB_EVIDENCE\",observed_at:new Date().toISOString(),\n lab:\"mosadek/brain-atomic-prod-sol1413\",production_helper_basis:\"val_native_kernel_v1.ts appendEvent adapted only tx context identifier\",\n results,totals:{commands:results.length,commands_passed:results.filter(x=>x.positive_ok&&x.all_rollback_exact).length,failure_boundaries:results.reduce((a,x)=>a+x.rollback_boundaries_total,0),rollback_passed:results.reduce((a,x)=>a+x.rollback_boundaries_passed,0)},\n pass:results.every(x=>x.positive_ok&&x.all_rollback_exact),canonical_brain_mutation:false,authority_mutation:false,direct_sprites_calls:0,human_authority_approval:false};\nconsole.log(JSON.stringify(report));\nexport default report;\n",[],[203],"4a5bf48c-b773-455f-a5a1-02ef4310c0a3","main.ts","a75d4a06-aab7-11f1-962a-1607ee4eb77e",5,["D",1788784359260],"import { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\nlet out:any={};\ntry{\n const t:any=await sqlite.transaction(\"write\");\n try{\n await t.execute(\"CREATE TABLE IF NOT EXISTS tx_probe(k TEXT PRIMARY KEY,v TEXT)\");\n await t.execute(\"DELETE FROM tx_probe\");\n await t.execute({sql:\"INSERT INTO tx_probe VALUES(?,?)\",args:[\"a\",\"1\"]});\n await t.rollback();\n }catch(e){try{await t.rollback()}catch{};throw e}\n const r:any=await sqlite.execute(\"SELECT COUNT(*) n FROM tx_probe\");\n out={ok:Number(r.rows[0].n)===0,n:Number(r.rows[0].n)};\n}catch(e){out={ok:false,error:e instanceof Error?e.message:String(e)}}\nconsole.log(JSON.stringify(out));\nexport default out;",[],[210],"76439bdc-bf1b-476f-9bc9-5a89b8632cb0","kernel_shadow.ts","01a07bd7-a8ee-73fc-a921-762337e0ce79",3,["D",1788784142270],"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 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 txExecuteInjected(tx:any,arg:any){\n atomicTestExecuteCalls++;\n const out=await tx.execute(arg);\n if(isWriteSql(arg)){\n atomicTestWriteCount++;\n if(atomicTestFailAfterWrite!==null&&atomicTestWriteCount===atomicTestFailAfterWrite){\n await new Promise(resolve=>setTimeout(resolve,0));\n throw new Error(\"ATOMIC_TEST_INJECT_AFTER_WRITE_\"+atomicTestWriteCount);\n }\n }\n return out;\n}\nexport function setAtomicTestFailureAfterWrite(n:number|null){\n atomicTestFailAfterWrite=n;\n atomicTestWriteCount=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}}\nconst sqlite:any={\n execute:async (...args:any[])=>{\n const tx:any=brainTxContext.getStore();\n return tx ? await txExecuteInjected(tx,args[0]) : await rootSqlite.execute(...args);\n },\n batch:async (statements:any[],mode?:any)=>{\n const tx:any=brainTxContext.getStore();\n if(!tx)return await rootSqlite.batch(statements,mode);\n const out:any[]=[];\n for(const st of statements)out.push(await txExecuteInjected(tx,st));\n return out;\n }\n};\nasync function withBrainWriteTransaction(fn:()=>Promise):Promise{\n atomicTestTxEntries++;\n const tx:any=await rootSqlite.transaction(\"write\");\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=\"svrec1864_\";\nlet P=\"atomicf9k3_\";\nexport function setAtomicTestPrefix(prefix:string){\n if(!/^atomic[a-z0-9_]+_$/.test(prefix))throw new Error(\"BAD_ATOMIC_TEST_PREFIX\");\n P=prefix;\n}\nconst PREDECESSOR_HEAD=\"d88a49daefd5520d5612c1bee960bcf7f587fc5f734a8e568b749e9bd390c1db\";\nconst PREDECESSOR_EVENTS=1991;\nconst enc=new TextEncoder();\nconst NON_AGENT=new Set([\"human_authority_approval\"]);\nconst SUPPORTED=new Set([\"status\",\"verify-chain\",\"verify-claim-graph\",\"register-agent\",\"ensure-task\",\"claim\",\"renew-lease\",\"recover-stale\",\"commit\"]);\nconst READ_ONLY_COMMANDS=new Set([\"status\",\"verify-chain\",\"verify-claim-graph\"]);\nconst EMERGENCY_MUTATIONS_FROZEN=true;\n\nfunction now(){return new Date().toISOString().replace(\"Z\",\"+00:00\")}\nfunction canon(x:any):string{\n if(x===null||typeof x!==\"object\")return JSON.stringify(x);\n if(Array.isArray(x))return \"[\"+x.map(canon).join(\",\")+\"]\";\n return \"{\"+Object.keys(x).sort().map(k=>JSON.stringify(k)+\":\"+canon(x[k])).join(\",\")+\"}\";\n}\nasync function sha(s:string){const d=await crypto.subtle.digest(\"SHA-256\",enc.encode(s));return[...new Uint8Array(d)].map(x=>x.toString(16).padStart(2,\"0\")).join(\"\")}\nasync function one(sql:string,args:any[]=[]){const r:any=await sqlite.execute({sql,args});return r.rows?.[0]??null}\nfunction flags(args:any[],start:number){const m:any={};for(let i=start;i=args.length)throw new Error(\"BAD_FLAG_VECTOR\");m[args[i].slice(2)]=args[i+1]}return m}\nfunction parseJson(s:any,kind:string){try{return JSON.parse(String(s))}catch{throw new Error(\"BAD_JSON_\"+kind)}}\nfunction exactTop(q:any){return q&&typeof q===\"object\"&&!Array.isArray(q)&&Object.keys(q).sort().join(\",\")===\"args,timeout\"&&Array.isArray(q.args)&&q.args.length>0&&q.args.every((x:any)=>typeof x===\"string\")&&Number.isInteger(q.timeout)&&q.timeout>=1&&q.timeout<=120}\nfunction cleanCaps(x:any){if(!Array.isArray(x)||x.some(v=>typeof v!==\"string\"||!v))throw new Error(\"CAPABILITIES_MUST_BE_STRING_LIST\");return [...new Set(x)].sort()}\nfunction cleanWrites(x:any){if(!Array.isArray(x)||x.some(v=>typeof v!==\"string\"||!v.trim()))throw new Error(\"WRITE_RESOURCES_MUST_BE_STRING_LIST\");return [...new Set(x.map((v:string)=>v.trim()))].sort()}\n\nasync function cloneState(){\n const tables=[\"meta\",\"workstreams\",\"agents\",\"tasks\",\"claims\",\"claim_deps\",\"artifacts\",\"replicas\",\"task_context_history\",\"task_invariant_history\",\"replay_log\",\"anchor\",\"epoch_events\",\"epoch_meta\"];\n for(const t of tables){await sqlite.execute(`DROP TABLE IF EXISTS ${P}${t}`);await sqlite.execute(`CREATE TABLE ${P}${t} AS SELECT * FROM ${SRC}${t}`)}\n await sqlite.execute(`DROP TABLE IF EXISTS ${Q}`);\n await sqlite.execute(`CREATE TABLE ${Q}(\n id TEXT PRIMARY KEY,priority REAL NOT NULL,payload_json TEXT NOT NULL,state TEXT NOT NULL,\n lease_owner TEXT,lease_attempt_id TEXT,lease_expires_at TEXT,result_json TEXT,error_json TEXT,\n created_at TEXT NOT NULL,updated_at TEXT NOT NULL)`);\n}\n\nasync function meta(){return await one(`SELECT * FROM ${P}epoch_meta WHERE id=1`)}\nasync function generation(){return Number((await meta()).generation)}\nasync function appendEvent(ws:string,agent:any,task:any,type:string,payload:any){\n if(!brainTxContext.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)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",[],[218],"88f549cb-7d57-4459-8aa8-6f1972ceaf97","concurrency.ts","bd23edee-aab8-11f1-8c57-1607ee4eb77e",13,["D",1788784601228],"import { sqlite as db } from \"https://esm.town/v/std/sqlite/main.ts\";\nimport {dispatchBrain,verifyBrainChain,setAtomicTestFailureAfterWrite,setAtomicTestPrefix} from \"./kernel_shadow.ts\";\nconst now=()=>new Date().toISOString().replace(\"Z\",\"+00:00\"), iso=(d:number)=>new Date(Date.now()+d).toISOString().replace(\"Z\",\"+00:00\");\nconst PREV=\"d88a49daefd5520d5612c1bee960bcf7f587fc5f734a8e568b749e9bd390c1db\";\nconst tables=[\"workstreams\",\"agents\",\"tasks\",\"epoch_events\",\"epoch_meta\"];\nasync function setup(p:string){\n setAtomicTestPrefix(p);\n for(const t of tables)try{await db.execute(`DROP TABLE IF EXISTS ${p}${t}`)}catch{}\n await db.execute(`CREATE TABLE ${p}workstreams(id TEXT PRIMARY KEY,mission TEXT,verified_state TEXT,head_generation INTEGER,updated_at TEXT)`);\n await db.execute(`CREATE TABLE ${p}agents(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 db.execute(`CREATE TABLE ${p}tasks(id TEXT PRIMARY KEY,workstream TEXT,state TEXT,priority REAL,depends_json TEXT,success_condition TEXT,decision_value TEXT,context_manifest TEXT,lease_owner TEXT,lease_mode TEXT,lease_generation INTEGER,lease_expires_at TEXT,created_at TEXT,updated_at TEXT,result_event_id INTEGER,requires_json TEXT,dedupe_key TEXT,assigned_agent TEXT,delegated_by TEXT,writes_json TEXT,guards_json TEXT)`);\n await db.execute(`CREATE TABLE ${p}epoch_events(local_seq INTEGER,event_uuid TEXT,ts TEXT,workstream TEXT,agent_id TEXT,task_id TEXT,type TEXT,payload_json TEXT,prev_hash TEXT,event_hash TEXT,transaction_generation INTEGER)`);\n await db.execute(`CREATE TABLE ${p}epoch_meta(id INTEGER PRIMARY KEY,epoch INTEGER,predecessor_generation INTEGER,predecessor_event_count INTEGER,predecessor_head TEXT,generation INTEGER,event_head_hash TEXT,new_event_count INTEGER,recovered_count INTEGER,ordering_policy TEXT,classification TEXT,created_at TEXT)`);\n await db.execute({sql:`INSERT INTO ${p}workstreams VALUES('global','x','{}',1864,?)`,args:[now()]});\n await db.execute({sql:`INSERT INTO ${p}epoch_meta VALUES(1,2,1863,1991,?,1864,?,0,0,'TEST','TEST',?)`,args:[PREV,PREV,now()]});\n}\nasync function cleanup(p:string){for(const t of tables)try{await db.execute(`DROP TABLE IF EXISTS ${p}${t}`)}catch{}}\nfunction norm(x:PromiseSettledResult){return x.status===\"fulfilled\"?{status:\"fulfilled\",value:x.value}:{status:\"rejected\",reason:x.reason instanceof Error?x.reason.message:String(x.reason)}}\nasync function scenarioRegisters(){\n const p=\"atomicconcra1413_\";await setup(p);setAtomicTestFailureAfterWrite(null);\n try{\n const q=(id:string)=>JSON.stringify({args:[\"register-agent\",id,\"--workstream\",\"global\",\"--role\",\"atomic-test\",\"--type\",\"CHAT\",\"--capabilities\",\"[]\"],timeout:60});\n const rs=await Promise.allSettled([dispatchBrain(q(\"agent-a\")),dispatchBrain(q(\"agent-b\"))]);\n const chain=await verifyBrainChain();\n const meta:any=(await db.execute(`SELECT generation,new_event_count,event_head_hash FROM ${p}epoch_meta WHERE id=1`)).rows[0];\n const agents:any=(await db.execute(`SELECT id,status FROM ${p}agents ORDER BY id`)).rows;\n const fulfilled=rs.filter(x=>x.status===\"fulfilled\"&&(x as PromiseFulfilledResult).value?.ok!==false).length;\n return {scenario:\"independent_concurrent_registers\",results:rs.map(norm),fulfilled,meta,agents,chain_ok:chain.ok,chain,\n pass:chain.ok&&agents.length===fulfilled&&Number(meta.new_event_count)===fulfilled&&Number(meta.generation)===1864+fulfilled};\n }finally{await cleanup(p)}\n}\nasync function scenarioClaims(){\n const p=\"atomicconcrc1413_\";await setup(p);setAtomicTestFailureAfterWrite(null);\n try{\n await db.execute({sql:`INSERT INTO ${p}agents VALUES('agent-a',NULL,'CHAT','global','atomic-test','READY',1864,1864,?,'[]'),('agent-b',NULL,'CHAT','global','atomic-test','READY',1864,1864,?,'[]')`,args:[now(),now()]});\n await db.execute({sql:`INSERT INTO ${p}tasks VALUES('task-1','global','READY',999999999,'[]','atomic test','atomic test','{}',NULL,NULL,NULL,NULL,?,?,NULL,'[]','atomic:test:task-1',NULL,NULL,'[]','[]')`,args:[iso(-1000),now()]});\n const q=(id:string)=>JSON.stringify({args:[\"claim\",\"--agent\",id,\"--mode\",\"INTERACTIVE\",\"--lease-seconds\",\"600\"],timeout:60});\n const rs=await Promise.allSettled([dispatchBrain(q(\"agent-a\")),dispatchBrain(q(\"agent-b\"))]);\n const chain=await verifyBrainChain();\n const task:any=(await db.execute(`SELECT id,state,lease_owner,lease_generation FROM ${p}tasks WHERE id='task-1'`)).rows[0];\n const meta:any=(await db.execute(`SELECT generation,new_event_count,event_head_hash FROM ${p}epoch_meta WHERE id=1`)).rows[0];\n const successes=rs.filter(x=>x.status===\"fulfilled\"&&(x as PromiseFulfilledResult).value?.ok===true).length;\n const leaseOwners=task?.lease_owner?[task.lease_owner]:[];\n return {scenario:\"competing_concurrent_claims\",results:rs.map(norm),successes,task,meta,chain_ok:chain.ok,chain,\n pass:chain.ok&&successes===1&&leaseOwners.length===1&&Number(meta.new_event_count)===1&&Number(meta.generation)===1865};\n }finally{await cleanup(p)}\n}\nconst a=await scenarioRegisters(),b=await scenarioClaims();\nconst out={schema:\"BRAIN_VAL_NATIVE_PRODUCTION_EQUIVALENT_CONCURRENCY_V1R1\",classification:\"VERIFIED_NONAUTHORITY_ISOLATED_LAB_EVIDENCE\",observed_at:new Date().toISOString(),lab:\"mosadek/brain-atomic-prod-sol1413\",scenarios:[a,b],pass:a.pass&&b.pass,canonical_brain_mutation:false,authority_mutation:false,direct_sprites_calls:0,human_authority_approval:false};\nconsole.log(JSON.stringify(out));export default out;",[],[226],["D",1788784118811],["D",1789477862254],{"_11":12,"_123":70},{"_11":12,"_118":119,"_69":70,"_30":68,"_120":121,"_122":24},{"_38":109,"_13":16,"_32":35,"_110":72,"_111":-5,"_112":-5,"_113":-5,"_114":-5,"_115":-5,"_116":14,"_117":12},"ctx",{"_53":-5,"_142":271,"_272":273,"_274":275,"_276":24,"_277":24,"_278":24,"_279":176,"_280":-5,"_281":-7,"_282":-7,"_283":26,"_284":24,"_285":24,"_286":-5,"_287":24,"_288":24,"_289":24,"_290":-5},"ENV",{"_242":243,"_244":245,"_246":16,"_247":248,"_249":250,"_251":252,"_253":254,"_255":256,"_257":258,"_259":260,"_261":262,"_263":264,"_265":266,"_267":268,"_269":270},"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"]

History · register_probe.ts