[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_220":221,"_222":223},"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-chain-fork-lab-0907","branchName","main","path","als_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","6b9f4441-2b7b-4e84-ab4c-86730307c736","branchId","2595f4e4-b0cd-44f6-9aa1-6540e43e2542","createdAt",["D",1788780688009],"version",5,"orgId","01a0715b-703f-741f-ab35-c85020e4a5e0","parentId","2dd96fac-01d9-4990-a258-e280019cf08e","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","aa741c0e-aaaf-11f1-8f46-1607ee4eb77e","fileType","script","deleted","6be0fc5c-1fef-4bd6-a1e1-67a3f8c0764e","avatar","https://lh3.googleusercontent.com/a/ACg8ocL1eT_LHhKSg5px3nXIO6eez79aZXef466qXKh2gak-0iwrvw=s96-c","deletedAtVersion","d3d259ed-f70f-4048-b75c-89c5e4b0dabe",["D",1788780278106],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","Disposable epoch2 chain linearization lab","imageUrl","pinnedFileId","pinPreview","pinMigrated","screenshotVersion","likeCount","tursoName","d3d259edf70f4048b75c89c5e4b0dabe","tursoHostname","d3d259edf70f4048b75c89c5e4b0dabe-val-town.aws-us-east-2.turso.io","tursoMeasuredAt",["D",1789476648181],"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",13,"projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","displayName","Mo Sadek","tier","free","canRestrictVals","profileImageUrl","adoptOrgId",{"_32":72,"_13":14,"_36":215,"_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":216,"_93":-5,"_94":95,"_96":95,"_97":98,"_99":98,"_100":98,"_101":95,"_102":95,"_53":217,"_104":218,"_106":219,"_108":24},"tree",[163,164,165,166,167,168],"files",[163,164,165,166,167,168],"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",{},"d6818392-354e-4db4-aaa2-560a94c57e72","content","import { AsyncLocalStorage } from \"node:async_hooks\";\nconst ctx=new AsyncLocalStorage();\nconst sleep=(ms:number)=>new Promise(r=>setTimeout(r,ms));\nasync function one(v:number,delay:number){\n return await ctx.run(v,async()=>{await sleep(delay);return {expected:v,observed:ctx.getStore()}});\n}\nconst out=await Promise.all([one(11,80),one(22,10),one(33,40)]);\nconsole.log(JSON.stringify({ok:out.every(x=>x.expected===x.observed),out}));\n",["D",1788780688009],"branchVersion","label",[18],"pulls","branches",1,"forks","envVars",{"_160":26,"_162":26},"connections",{"_160":26,"_161":26},"count","unfilledCount","emptyCount",{"_32":145,"_13":18,"_63":64,"_42":-5,"_34":35,"_149":39,"_173":174,"_36":212,"_38":26,"_65":66,"_146":147,"_67":24,"_150":-5,"_177":213,"_17":214},{"_32":204,"_13":205,"_63":206,"_42":-5,"_34":35,"_149":207,"_173":174,"_36":208,"_38":154,"_65":66,"_146":209,"_67":24,"_150":-5,"_177":210,"_17":211},{"_32":195,"_13":196,"_63":197,"_42":-5,"_34":35,"_149":198,"_173":174,"_36":199,"_38":200,"_65":66,"_146":201,"_67":24,"_150":-5,"_177":202,"_17":203},{"_32":187,"_13":188,"_63":189,"_42":-5,"_34":35,"_149":190,"_173":174,"_36":191,"_38":26,"_65":66,"_146":192,"_67":24,"_150":-5,"_177":193,"_17":194},{"_32":180,"_13":181,"_63":182,"_42":-5,"_34":35,"_149":109,"_173":174,"_36":183,"_38":26,"_65":66,"_146":184,"_67":24,"_150":-5,"_177":185,"_17":186},{"_32":169,"_13":170,"_63":171,"_42":-5,"_34":35,"_149":172,"_173":174,"_36":175,"_38":26,"_65":66,"_146":176,"_67":24,"_150":-5,"_177":178,"_17":179},"12876b57-821d-40e0-8cba-a64aeec41c12","semantic_tx_context_probe.ts","31287218-aab0-11f1-8d68-1607ee4eb77e",9,"latest",true,["D",1788780914070],"import { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\nimport { AsyncLocalStorage } from \"node:async_hooks\";\n\nconst P=\"semantic_tx_\"+Date.now()+\"_\"+Math.random().toString(16).slice(2,8);\nconst META=P+\"_meta\", EVENTS=P+\"_events\", TASKS=P+\"_tasks\", AGENTS=P+\"_agents\", WS=P+\"_ws\";\nconst ctx=new AsyncLocalStorage();\nlet injectAt:number|null=null, step=0;\nfunction inject(){step++; if(injectAt===step) throw new Error(\"INJECT_\"+step)}\nasync function db(q:any){const tx=ctx.getStore(); return tx?await tx.execute(q):await sqlite.execute(q)}\nasync function one(q:any){return (await db(q)).rows?.[0] as any}\nasync function withWriteTx(fn:()=>Promise):Promise{\n const tx=await sqlite.transaction(\"write\");\n try{\n const out=await ctx.run(tx,fn);\n await tx.commit();\n return out;\n }catch(e){\n try{await tx.rollback()}catch{}\n throw e;\n }\n}\nasync function init(){\n await sqlite.execute(`CREATE TABLE ${META}(id INTEGER PRIMARY KEY,head TEXT NOT NULL,generation INTEGER NOT NULL,event_count INTEGER NOT NULL)`);\n await sqlite.execute(`CREATE TABLE ${EVENTS}(seq INTEGER PRIMARY KEY,kind TEXT NOT NULL,task_id TEXT,prev TEXT NOT NULL,hash TEXT NOT NULL)`);\n await sqlite.execute(`CREATE TABLE ${TASKS}(id TEXT PRIMARY KEY,state TEXT NOT NULL,owner TEXT)`);\n await sqlite.execute(`CREATE TABLE ${AGENTS}(id TEXT PRIMARY KEY,status TEXT NOT NULL)`);\n await sqlite.execute(`CREATE TABLE ${WS}(id TEXT PRIMARY KEY,head_generation INTEGER NOT NULL)`);\n await sqlite.execute({sql:`INSERT INTO ${META} VALUES(1,'GENESIS',100,0)`});\n await sqlite.execute({sql:`INSERT INTO ${TASKS} VALUES('T','READY',NULL)`});\n await sqlite.execute({sql:`INSERT INTO ${AGENTS} VALUES('A','READY')`});\n await sqlite.execute({sql:`INSERT INTO ${WS} VALUES('global',100)`});\n}\nasync function snapshot(){\n const [m,e,t,a,w]=await Promise.all([\n sqlite.execute(`SELECT * FROM ${META}`),\n sqlite.execute(`SELECT * FROM ${EVENTS} ORDER BY seq`),\n sqlite.execute(`SELECT * FROM ${TASKS}`),\n sqlite.execute(`SELECT * FROM ${AGENTS}`),\n sqlite.execute(`SELECT * FROM ${WS}`)\n ]);\n return {meta:m.rows,events:e.rows,tasks:t.rows,agents:a.rows,ws:w.rows};\n}\nconst canon=(x:any)=>JSON.stringify(x);\nasync function appendEvent(kind:string,taskId:string){\n const m:any=await one(`SELECT * FROM ${META} WHERE id=1`);\n const n:any=await one(`SELECT COALESCE(MAX(seq),0)+1 n FROM ${EVENTS}`);\n const seq=Number(n.n), h=`${m.head}|${seq}|${kind}|${taskId}`;\n await db({sql:`INSERT INTO ${EVENTS}(seq,kind,task_id,prev,hash) VALUES(?,?,?,?,?)`,args:[seq,kind,taskId,m.head,h]}); inject();\n await db({sql:`UPDATE ${META} SET head=?,event_count=event_count+1 WHERE id=1`,args:[h]}); inject();\n}\nasync function claim(){\n return await withWriteTx(async()=>{\n const t:any=await one(`SELECT * FROM ${TASKS} WHERE id='T'`);\n if(t.state!==\"READY\") throw new Error(\"TASK_NOT_READY\");\n await db(`UPDATE ${TASKS} SET state='LEASED',owner='A' WHERE id='T'`); inject();\n await appendEvent(\"TASK_LEASED\",\"T\");\n await db(`UPDATE ${META} SET generation=generation+1 WHERE id=1`); inject();\n const g:any=await one(`SELECT generation FROM ${META} WHERE id=1`);\n await db(`UPDATE ${AGENTS} SET status='WORKING' WHERE id='A'`); inject();\n await db({sql:`UPDATE ${WS} SET head_generation=? WHERE id='global'`,args:[g.generation]}); inject();\n return {generation:Number(g.generation)};\n });\n}\nasync function reset(){\n await sqlite.execute(`DELETE FROM ${EVENTS}`);\n await sqlite.execute(`UPDATE ${META} SET head='GENESIS',generation=100,event_count=0 WHERE id=1`);\n await sqlite.execute(`UPDATE ${TASKS} SET state='READY',owner=NULL WHERE id='T'`);\n await sqlite.execute(`UPDATE ${AGENTS} SET status='READY' WHERE id='A'`);\n await sqlite.execute(`UPDATE ${WS} SET head_generation=100 WHERE id='global'`);\n}\nasync function rawBypassNegative(){\n await reset(); const before=await snapshot();\n let err=\"\";\n try{\n await withWriteTx(async()=>{\n await sqlite.execute(`UPDATE ${TASKS} SET state='LEASED',owner='RAW' WHERE id='T'`);\n throw new Error(\"AFTER_RAW_DIRECT_WRITE\");\n });\n }catch(e){err=e instanceof Error?e.message:String(e)}\n const after=await snapshot();\n return {pass:canon(before)!==canon(after)&&String((after.tasks as any)[0].owner)===\"RAW\",error:err,before,after};\n}\nasync function run(){\n await init();\n const tests:any[]=[];\n // Seven injected boundaries: task write, event insert, event head, generation bump, agent write, workstream write; plus completion.\n for(let i=1;i<=6;i++){\n await reset(); const before=await snapshot(); injectAt=i;step=0;let err=\"\";\n try{await claim()}catch(e){err=e instanceof Error?e.message:String(e)}\n injectAt=null; const after=await snapshot();\n tests.push({id:`ROLLBACK_AFTER_BOUNDARY_${i}`,pass:canon(before)===canon(after),error:err});\n }\n await reset();injectAt=null;step=0;const ok=await claim(),success=await snapshot();\n tests.push({id:\"SUCCESS_COMMITS_ALL_SEMANTIC_WRITES\",pass:(success.tasks as any)[0].state===\"LEASED\"&&(success.agents as any)[0].status===\"WORKING\"&&(success.events as any).length===1&&(success.meta as any)[0].generation===101&&(success.ws as any)[0].head_generation===101,result:ok});\n const raw=await rawBypassNegative();\n tests.push({id:\"RAW_SQLITE_BYPASS_NEGATIVE_CONTROL\",pass:raw.pass,meaning:\"A raw sqlite.execute inside the command escapes the transaction and survives rollback; production repair must route every semantic helper/write through the command-scoped adapter.\",error:raw.error});\n await reset();\n const concurrent=await Promise.allSettled([claim(),claim()]);\n const c=await snapshot();\n const successes=concurrent.filter(x=>x.status===\"fulfilled\").length, failures=concurrent.length-successes;\n tests.push({id:\"CONCURRENT_COMMANDS_SERIALIZE_AND_PRESERVE_SINGLE_CLAIM\",pass:successes===1&&failures===1&&(c.events as any).length===1&&(c.meta as any)[0].generation===101,concurrent});\n const passed=tests.filter(x=>x.pass).length;\n const receipt={schema:\"BRAIN_EPOCH2_COMMAND_SCOPED_TX_CONTEXT_PROBE_V1\",classification:\"DISPOSABLE_NONAUTHORITY_EMPIRICAL_SUPPORT\",tests,passed,failed:tests.length-passed,implications:[\n \"AsyncLocalStorage can route nested helpers such as appendEvent through the command-scoped write transaction.\",\n \"Injected failures after every modeled semantic write boundary roll back domain state, event/head, generation, agent and workstream state together.\",\n \"Any remaining direct sqlite.execute call inside a semantic command is a transaction escape hatch and must be statically prohibited or explicitly proven read-only.\",\n \"The production fix still requires coverage of every real mutator and exact production invariants; this probe is not authority or promotion.\"\n ],direct_sprites_calls:0,human_authority_approval:false};\n console.log(JSON.stringify(receipt,null,2));\n for(const t of [EVENTS,TASKS,AGENTS,WS,META]) await sqlite.execute(`DROP TABLE IF EXISTS ${t}`);\n return receipt;\n}\nawait run();\n","children",[],[170],"614a20bd-2248-4e74-91f1-afe21afad010","quarantine_verifier_adversarial_v1.ts","5f26c2d6-aab1-11f1-9938-1607ee4eb77e",["D",1788781420703],"type Q={local_seq:number,event_uuid:string,event_hash:string,reason:string,forensic_uri:string};\nfunction candidateAllows(activeSeq:number[],q:Q[]){\n const s=new Set(activeSeq),max=Math.max(...activeSeq),missing:number[]=[];\n for(let i=1;i<=max;i++)if(!s.has(i))missing.push(i);\n const qs=new Set(q.map(x=>x.local_seq));\n const missingWithout=missing.filter(x=>!qs.has(x));\n const still=q.filter(x=>s.has(x.local_seq));\n const extra=q.filter(x=>x.local_seq<1||x.local_seq>max||!missing.includes(x.local_seq));\n const malformed=q.filter(x=>!/^[0-9a-f]{64}$/.test(x.event_hash)||!x.event_uuid||!x.reason||!x.forensic_uri.startsWith(\"valblob:\"));\n return missingWithout.length===0&&still.length===0&&extra.length===0&&malformed.length===0;\n}\nconst forged:Q={local_seq:2,event_uuid:\"forged\",event_hash:\"0\".repeat(64),reason:\"TRUST_ME\",forensic_uri:\"valblob:does/not/exist\"};\nconst wrongHash:Q={...forged,event_uuid:\"forged2\",event_hash:\"f\".repeat(64),forensic_uri:\"valblob:mosadek/project-brain-live-v1-durable/evidence/not-the-orphan.json\"};\nconst cases=[\n {id:\"FORGED_NONEXISTENT_FORENSIC_URI\",accepted:candidateAllows([1,3],[forged]),should_accept:false},\n {id:\"WRONG_ORPHAN_HASH_WITH_PLAUSIBLE_URI\",accepted:candidateAllows([1,3],[wrongHash]),should_accept:false},\n {id:\"DUPLICATE_QUARANTINE_ROWS_SAME_SEQ\",accepted:candidateAllows([1,3],[forged,{...wrongHash,local_seq:2}]),should_accept:false}\n];\nconst failures=cases.filter(x=>x.accepted!==x.should_accept);\nconsole.log(JSON.stringify({schema:\"QUARANTINE_VERIFIER_CANDIDATE_ADVERSARIAL_V1\",cases,security_failures:failures.map(x=>x.id),pass:failures.length===0,verdict:failures.length?\"REJECT_CANDIDATE_UNTIL_FORENSIC_BINDING\":\"PASS\"},null,2));",[],[181],"bf354ca1-061b-4001-9e50-93bf00871d8c","probe_prod_kernel_public_surface_v1.ts","f2ab8c54-aab0-11f1-9403-1607ee4eb77e",12,["D",1788781238726],"import { brainStatus, verifyBrainChain, verifyBrainClaimGraph, registerBrainAgent } from \"https://esm.town/v/mosadek/project-brain-live-v1-durable/val_native_kernel_v1.ts\";\nconst before:any=await brainStatus();\nconst chain:any=await verifyBrainChain();\nconst graph:any=await verifyBrainClaimGraph();\nconst reg:any=await registerBrainAgent([\"register-agent\",\"probe-must-not-exist-sol-v1788\",\"--workstream\",\"global\",\"--role\",\"freeze-probe\",\"--type\",\"CHAT\",\"--capabilities\",\"[]\"]);\nconst after:any=await brainStatus();\nconsole.log(JSON.stringify({\n schema:\"EPOCH2_KERNEL_PUBLIC_SURFACE_FREEZE_PROBE_V1\",\n before:{generation:before?.generation,agents:before?.counts?.agents},\n chain:{ok:chain?.ok,structural_problem_count:chain?.structural_problems?.length,first_structural:chain?.structural_problems?.slice?.(0,2)},\n graph:{ok:graph?.ok,claims:graph?.claims,problem_count:graph?.problems?.length},\n mutator_result:reg,\n after:{generation:after?.generation,agents:after?.counts?.agents},\n pass:before?.generation===after?.generation&&before?.counts?.agents===after?.counts?.agents&®?.ok===false&®?.reason===\"VAL_NATIVE_MUTATIONS_EMERGENCY_FROZEN\",\n direct_sprites_calls:0,human_authority_approval:false\n},null,2));",[],[188],"78fe6626-9513-4ebb-aba2-2c82f9ab8589","main.ts","b61e86bc-aaae-11f1-b19b-1607ee4eb77e",11,["D",1788781078667],6,"import { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\nimport { AsyncLocalStorage } from \"node:async_hooks\";\n\nconst P=\"txproxy_\"+Date.now()+\"_\"+Math.random().toString(16).slice(2,8);\nconst M=P+\"_meta\",E=P+\"_events\",T=P+\"_tasks\",A=P+\"_agents\",W=P+\"_ws\";\nconst ctx=new AsyncLocalStorage();\nconst enc=new TextEncoder();\nconst sleep=(ms:number)=>new Promise(r=>setTimeout(r,ms));\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(\"\")}\nfunction db(){return ctx.getStore()??sqlite}\nasync function ex(q:any){return await db().execute(q)}\nasync function one(sql:string,args:any[]=[]){return (await ex({sql,args})).rows?.[0] as any}\nasync function init(){\n for(const x of [E,T,A,W,M])await sqlite.execute(`DROP TABLE IF EXISTS ${x}`);\n await sqlite.execute(`CREATE TABLE ${M}(id INTEGER PRIMARY KEY CHECK(id=1),head TEXT NOT NULL,generation INTEGER NOT NULL,event_count INTEGER NOT NULL)`);\n await sqlite.execute(`CREATE TABLE ${E}(seq INTEGER PRIMARY KEY,event_uuid TEXT UNIQUE NOT NULL,prev TEXT NOT NULL,hash TEXT UNIQUE NOT NULL,kind TEXT NOT NULL,payload TEXT NOT NULL,tx_generation INTEGER NOT NULL)`);\n await sqlite.execute(`CREATE TABLE ${T}(id TEXT PRIMARY KEY,state TEXT NOT NULL,owner TEXT)`);\n await sqlite.execute(`CREATE TABLE ${A}(id TEXT PRIMARY KEY,status TEXT NOT NULL,last_generation INTEGER NOT NULL)`);\n await sqlite.execute(`CREATE TABLE ${W}(id TEXT PRIMARY KEY,head_generation INTEGER NOT NULL)`);\n await sqlite.execute({sql:`INSERT INTO ${M} VALUES(1,'GENESIS',0,0)`});\n await sqlite.execute({sql:`INSERT INTO ${T} VALUES('t1','READY',NULL),('t2','READY',NULL)`});\n await sqlite.execute({sql:`INSERT INTO ${A} VALUES('a1','READY',0),('a2','READY',0)`});\n await sqlite.execute({sql:`INSERT INTO ${W} VALUES('global',0)`});\n}\nasync function cleanup(){for(const x of [E,T,A,W,M])await sqlite.execute(`DROP TABLE IF EXISTS ${x}`)}\nasync function withTx(fn:()=>Promise):Promise{\n const tx=await sqlite.transaction(\"write\");\n try{\n const v=await ctx.run(tx,fn);\n await tx.commit();\n return v;\n }catch(e){\n try{await tx.rollback()}catch{}\n throw e;\n }\n}\nasync function append(kind:string,payload:any){\n const m:any=await one(`SELECT * FROM ${M} WHERE id=1`);\n const seq=Number((await one(`SELECT COALESCE(MAX(seq),0)+1 n FROM ${E}`)).n);\n const uuid=crypto.randomUUID(),prev=String(m.head),raw=JSON.stringify(payload),h=await sha(uuid+\"|\"+seq+\"|\"+prev+\"|\"+kind+\"|\"+raw+\"|\"+m.generation);\n await ex({sql:`INSERT INTO ${E}(seq,event_uuid,prev,hash,kind,payload,tx_generation) VALUES(?,?,?,?,?,?,?)`,args:[seq,uuid,prev,h,kind,raw,Number(m.generation)]});\n await ex({sql:`UPDATE ${M} SET head=?,event_count=event_count+1 WHERE id=1 AND head=? AND generation=?`,args:[h,prev,Number(m.generation)]});\n return {seq,h};\n}\nasync function bump(){return Number((await ex(`UPDATE ${M} SET generation=generation+1 WHERE id=1 RETURNING generation`)).rows?.[0]?.generation)}\ntype Point=\"AFTER_TASK\"|\"AFTER_EVENT\"|\"AFTER_BUMP\"|\"AFTER_AGENT\"|\"AFTER_WS\"|null;\nasync function claim(agent:string,task:string,fail:Point=null,delay=0){\n return await withTx(async()=>{\n const m:any=await one(`SELECT generation FROM ${M} WHERE id=1`);\n const u=await ex({sql:`UPDATE ${T} SET state='LEASED',owner=? WHERE id=? AND state='READY' RETURNING id`,args:[agent,task]});\n if(!(u.rows||[]).length)throw new Error(\"NOT_READY\");\n if(fail===\"AFTER_TASK\")throw new Error(fail);\n if(delay)await sleep(delay);\n await append(\"TASK_LEASED\",{agent,task});\n if(fail===\"AFTER_EVENT\")throw new Error(fail);\n const g=await bump();\n if(fail===\"AFTER_BUMP\")throw new Error(fail);\n await ex({sql:`UPDATE ${A} SET status='WORKING',last_generation=? WHERE id=?`,args:[g,agent]});\n if(fail===\"AFTER_AGENT\")throw new Error(fail);\n await ex({sql:`UPDATE ${W} SET head_generation=? WHERE id='global'`,args:[g]});\n if(fail===\"AFTER_WS\")throw new Error(fail);\n return {generation:g,lease_generation:Number(m.generation)};\n });\n}\nasync function snapshot(){\n const m=await sqlite.execute(`SELECT * FROM ${M}`),e=await sqlite.execute(`SELECT * FROM ${E} ORDER BY seq`),t=await sqlite.execute(`SELECT * FROM ${T} ORDER BY id`),a=await sqlite.execute(`SELECT * FROM ${A} ORDER BY id`),w=await sqlite.execute(`SELECT * FROM ${W}`);\n return {meta:m.rows?.[0],events:e.rows,tasks:t.rows,agents:a.rows,ws:w.rows?.[0]};\n}\nfunction equal(a:any,b:any){return JSON.stringify(a)===JSON.stringify(b)}\nasync function run(){\n await init();\n const tests:any[]=[];\n const baseline=await snapshot();\n for(const p of [\"AFTER_TASK\",\"AFTER_EVENT\",\"AFTER_BUMP\",\"AFTER_AGENT\",\"AFTER_WS\"] as Point[]){\n let err=\"\";\n try{await claim(\"a1\",\"t1\",p)}catch(e){err=e instanceof Error?e.message:String(e)}\n const after=await snapshot();\n tests.push({id:\"ROLLBACK_\"+p,pass:equal(after,baseline),error:err,after});\n }\n const c=await Promise.allSettled([claim(\"a1\",\"t1\",null,400),claim(\"a2\",\"t2\",null,0)]);\n const afterConcurrent=await snapshot();\n let prev=\"GENESIS\",bad:any[]=[];\n for(const x of afterConcurrent.events as any[]){if(x.prev!==prev)bad.push({seq:x.seq,expected:prev,actual:x.prev});prev=x.hash}\n const concPass=c.every(x=>x.status===\"fulfilled\")&&bad.length===0&&(afterConcurrent.meta as any).head===prev&&(afterConcurrent.meta as any).generation===2&&(afterConcurrent.meta as any).event_count===2&&(afterConcurrent.events as any[]).length===2;\n tests.push({id:\"CONCURRENT_FULL_COMMANDS_LINEARIZE\",pass:concPass,results:c,observation:afterConcurrent,bad});\n const receipt={schema:\"VAL_NATIVE_ASYNC_LOCAL_FULL_COMMAND_TX_PROXY_V1\",classification:\"DISPOSABLE_NONAUTHORITY\",tests,passed:tests.filter(x=>x.pass).length,failed:tests.filter(x=>!x.pass).length,implication:\"AsyncLocalStorage transaction routing can make an existing multi-helper command atomic with low-churn helper reuse: all injected boundaries rollback and concurrent full semantic commands linearize in this fixture.\",nonclaim:\"Production kernel still requires every mutator/helper audited, checkpoint two-phase handling, recovery lineage, unknown-outcome fencing and independent validation.\",direct_sprites_calls:0,human_authority_approval:false};\n await cleanup();\n console.log(JSON.stringify(receipt));\n return receipt;\n}\nawait run();\n",[],[196],"a2cd28d3-0278-4c92-b9cb-5411ed7fda1b","command_tx_probe.ts","18044578-aab0-11f1-8062-1607ee4eb77e",10,["D",1788780987553],"import { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\nimport { AsyncLocalStorage } from \"node:async_hooks\";\nconst C=\"cmdtx_\"+Date.now()+\"_\"+Math.random().toString(16).slice(2,8);\nconst T=(n:string)=>C+\"_\"+n;\nconst ctx=new AsyncLocalStorage();\nconst q=()=>ctx.getStore()??sqlite;\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 exec(sql:string,args:any[]=[]){return await q().execute({sql,args})}\nasync function one(sql:string,args:any[]=[]){return (await exec(sql,args)).rows?.[0] as any}\nasync function init(){\n for(const n of [\"events\",\"tasks\",\"agents\",\"meta\",\"workstreams\"])await sqlite.execute(`DROP TABLE IF EXISTS ${T(n)}`);\n await sqlite.execute(`CREATE TABLE ${T(\"meta\")}(id INTEGER PRIMARY KEY,head TEXT NOT NULL,generation INTEGER NOT NULL,count INTEGER NOT NULL)`);\n await sqlite.execute(`CREATE TABLE ${T(\"workstreams\")}(id TEXT PRIMARY KEY,head_generation INTEGER NOT NULL)`);\n await sqlite.execute(`CREATE TABLE ${T(\"agents\")}(id TEXT PRIMARY KEY,status TEXT NOT NULL,last_generation INTEGER NOT NULL)`);\n await sqlite.execute(`CREATE TABLE ${T(\"tasks\")}(id TEXT PRIMARY KEY,state TEXT NOT NULL,lease_owner TEXT,result_hash TEXT)`);\n await sqlite.execute(`CREATE TABLE ${T(\"events\")}(seq INTEGER PRIMARY KEY,type TEXT NOT NULL,agent TEXT,task TEXT,prev TEXT NOT NULL,hash TEXT NOT NULL)`);\n await sqlite.execute({sql:`INSERT INTO ${T(\"meta\")} VALUES(1,'GENESIS',0,0)`});\n await sqlite.execute({sql:`INSERT INTO ${T(\"workstreams\")} VALUES('global',0)`});\n}\nasync function snap(){\n const [m,w,a,t,e]=await Promise.all([\n sqlite.execute(`SELECT * FROM ${T(\"meta\")}`),sqlite.execute(`SELECT * FROM ${T(\"workstreams\")}`),\n sqlite.execute(`SELECT * FROM ${T(\"agents\")} ORDER BY id`),sqlite.execute(`SELECT * FROM ${T(\"tasks\")} ORDER BY id`),\n sqlite.execute(`SELECT * FROM ${T(\"events\")} ORDER BY seq`)\n ]);\n return {m:m.rows,w:w.rows,a:a.rows,t:t.rows,e:e.rows};\n}\nasync function chain(){\n const s:any=await snap();let prev=\"GENESIS\",bad:any[]=[];\n for(const x of s.e){if(x.prev!==prev)bad.push({seq:x.seq,expected:prev,actual:x.prev});prev=x.hash}\n const m:any=s.m[0];return{ok:bad.length===0&&m.head===prev&&Number(m.count)===s.e.length,bad,s};\n}\nasync function event(type:string,agent:string|null,task:string|null){\n const m:any=await one(`SELECT * FROM ${T(\"meta\")} WHERE id=1`);\n const seq=Number((await one(`SELECT COALESCE(MAX(seq),0)+1 n FROM ${T(\"events\")}`)).n);\n const h=await sha([seq,type,agent??\"\",task??\"\",m.head].join(\"|\"));\n await exec(`INSERT INTO ${T(\"events\")}(seq,type,agent,task,prev,hash) VALUES(?,?,?,?,?,?)`,[seq,type,agent,task,m.head,h]);\n return {seq,h,oldHead:m.head};\n}\nfunction inject(point:string,want?:string){if(want===point)throw new Error(\"INJECT_\"+point)}\nasync function withMutation(fn:()=>Promise){\n const tx=await sqlite.transaction(\"write\");\n try{const out=await ctx.run(tx,fn);await tx.commit();return{ok:true,out}}\n catch(e){await tx.rollback();return{ok:false,error:e instanceof Error?e.message:String(e)}}\n}\nasync function register(agent:string,fail?:string){return await withMutation(async()=>{\n const g=Number((await one(`SELECT generation FROM ${T(\"meta\")} WHERE id=1`)).generation);\n await exec(`INSERT INTO ${T(\"agents\")}(id,status,last_generation) VALUES(?,'READY',?)`,[agent,g]);inject(\"REGISTER_AGENT_INSERT\",fail);\n const ev=await event(\"AGENT_REGISTERED\",agent,null);inject(\"REGISTER_EVENT\",fail);\n await exec(`UPDATE ${T(\"meta\")} SET head=?,generation=generation+1,count=count+1 WHERE id=1`,[ev.h]);inject(\"REGISTER_META\",fail);\n const ng=Number((await one(`SELECT generation FROM ${T(\"meta\")} WHERE id=1`)).generation);\n await exec(`UPDATE ${T(\"agents\")} SET last_generation=? WHERE id=?`,[ng,agent]);inject(\"REGISTER_AGENT_HEAD\",fail);\n await exec(`UPDATE ${T(\"workstreams\")} SET head_generation=? WHERE id='global'`,[ng]);inject(\"REGISTER_WS\",fail);\n return {ng};\n})}\nasync function seedTask(id:string){await sqlite.execute({sql:`INSERT INTO ${T(\"tasks\")}(id,state,lease_owner,result_hash) VALUES(?,'READY',NULL,NULL)`,args:[id]})}\nasync function claim(task:string,agent:string,fail?:string){return await withMutation(async()=>{\n const t:any=await one(`SELECT * FROM ${T(\"tasks\")} WHERE id=?`,[task]);if(!t||t.state!==\"READY\")return{claimed:false};\n await exec(`UPDATE ${T(\"tasks\")} SET state='LEASED',lease_owner=? WHERE id=? AND state='READY'`,[agent,task]);inject(\"CLAIM_TASK\",fail);\n const ev=await event(\"TASK_LEASED\",agent,task);inject(\"CLAIM_EVENT\",fail);\n await exec(`UPDATE ${T(\"meta\")} SET head=?,generation=generation+1,count=count+1 WHERE id=1`,[ev.h]);inject(\"CLAIM_META\",fail);\n const ng=Number((await one(`SELECT generation FROM ${T(\"meta\")} WHERE id=1`)).generation);\n await exec(`UPDATE ${T(\"agents\")} SET status='WORKING',last_generation=? WHERE id=?`,[ng,agent]);inject(\"CLAIM_AGENT\",fail);\n await exec(`UPDATE ${T(\"workstreams\")} SET head_generation=? WHERE id='global'`,[ng]);inject(\"CLAIM_WS\",fail);\n return{claimed:true,ng};\n})}\nasync function commit(task:string,agent:string,fail?:string){return await withMutation(async()=>{\n const t:any=await one(`SELECT * FROM ${T(\"tasks\")} WHERE id=?`,[task]);if(!t||t.state!==\"LEASED\"||t.lease_owner!==agent)throw new Error(\"NOT_OWNER\");\n const ev=await event(\"TASK_RESULT_COMMITTED\",agent,task);inject(\"COMMIT_EVENT\",fail);\n const rh=await sha(\"result:\"+task);\n await exec(`UPDATE ${T(\"tasks\")} SET state='COMPLETE',lease_owner=NULL,result_hash=? WHERE id=?`,[rh,task]);inject(\"COMMIT_TASK\",fail);\n await exec(`UPDATE ${T(\"meta\")} SET head=?,generation=generation+1,count=count+1 WHERE id=1`,[ev.h]);inject(\"COMMIT_META\",fail);\n const ng=Number((await one(`SELECT generation FROM ${T(\"meta\")} WHERE id=1`)).generation);\n await exec(`UPDATE ${T(\"agents\")} SET status='READY',last_generation=? WHERE id=?`,[ng,agent]);inject(\"COMMIT_AGENT\",fail);\n await exec(`UPDATE ${T(\"workstreams\")} SET head_generation=? WHERE id='global'`,[ng]);inject(\"COMMIT_WS\",fail);\n return{ng};\n})}\nasync function expectRollback(name:string,op:()=>Promise){\n const before=JSON.stringify(await snap());const r=await op();const after=JSON.stringify(await snap());\n return{id:name,pass:r.ok===false&&before===after,result:r};\n}\nasync function cleanup(){for(const n of [\"events\",\"tasks\",\"agents\",\"meta\",\"workstreams\"])await sqlite.execute(`DROP TABLE IF EXISTS ${T(n)}`)}\nawait init();const tests:any[]=[];\nfor(const p of [\"REGISTER_AGENT_INSERT\",\"REGISTER_EVENT\",\"REGISTER_META\",\"REGISTER_AGENT_HEAD\",\"REGISTER_WS\"]){\n tests.push(await expectRollback(p,()=>register(\"r_\"+p,p)));\n}\nconst r0=await register(\"A\");await seedTask(\"t1\");\nfor(const p of [\"CLAIM_TASK\",\"CLAIM_EVENT\",\"CLAIM_META\",\"CLAIM_AGENT\",\"CLAIM_WS\"]){\n const base=await snap();await sqlite.execute(`DELETE FROM ${T(\"events\")} WHERE seq>(SELECT count FROM ${T(\"meta\")} WHERE id=1)`);\n tests.push(await expectRollback(p,()=>claim(\"t1\",\"A\",p)));\n}\nconst c0=await claim(\"t1\",\"A\");\nfor(const p of [\"COMMIT_EVENT\",\"COMMIT_TASK\",\"COMMIT_META\",\"COMMIT_AGENT\",\"COMMIT_WS\"]){\n tests.push(await expectRollback(p,()=>commit(\"t1\",\"A\",p)));\n}\nconst cm=await commit(\"t1\",\"A\");\nawait seedTask(\"c1\");await seedTask(\"c2\");\nconst cc=await Promise.all([claim(\"c1\",\"A\"),claim(\"c2\",\"A\")]);\nconst final=await chain();\ntests.push({id:\"CONCURRENT_MUTATIONS_LINEAR_CHAIN\",pass:cc.every(x=>x.ok)&&final.ok,results:cc});\nconst receipt={schema:\"COMMAND_WIDE_ASYNC_LOCAL_TX_PROBE_V1\",classification:\"DISPOSABLE_NONAUTHORITY\",als_route:\"AsyncLocalStorage transaction context\",tests_passed:tests.filter(x=>x.pass).length,tests_failed:tests.filter(x=>!x.pass).length,tests,final_chain_ok:final.ok,baseline:{register:r0,claim:c0,commit:cm},repair_implication:\"A shared async-local transaction client can give existing nested helpers one command-wide write transaction without a global mutable DB handle. Every mutator still needs production differential testing and external-effect handling.\",direct_sprites_calls:0,human_authority_approval:false};\nconsole.log(JSON.stringify(receipt));await cleanup();",[],[205],["D",1788780688009],[],[18],["D",1788780278106],["D",1789476648181],{"_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":253,"_254":255,"_256":257,"_258":24,"_259":24,"_260":24,"_261":174,"_262":-5,"_263":-7,"_264":-7,"_265":26,"_266":24,"_267":24,"_268":-5,"_269":24,"_270":24,"_271":24,"_272":-5},"ENV",{"_224":225,"_226":227,"_228":16,"_229":230,"_231":232,"_233":234,"_235":236,"_237":238,"_239":240,"_241":242,"_243":244,"_245":246,"_247":248,"_249":250,"_251":252},"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 · als_probe.ts