[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_192":193,"_194":195},"routes/_app.x.$handle.$name",{"_96":95,"_31":43,"_105":86,"_26":106,"_13":14,"_107":-5,"_11":108,"_109":110,"_111":112,"_113":114,"_115":116,"_20":-5,"_117":-5,"_118":-5,"_119":24,"_120":121,"_122":24,"_123":-5,"_124":-5,"_125":126},"routes/_app.x.$handle.$name.branch.$branch.version.$version.diff",{"_11":12,"_13":14,"_15":16,"_17":-5,"_18":-5},"project",{"_41":42,"_31":43,"_36":44,"_45":-5,"_46":24,"_47":48,"_49":48,"_50":51,"_52":-5,"_18":53,"_54":-5,"_55":24,"_56":-5,"_57":-5,"_58":59,"_60":61,"_62":63,"_64":65,"_66":67,"_68":-5,"_69":70,"_71":70,"_72":73,"_74":73,"_75":73,"_76":70,"_77":70,"_78":79,"_80":81,"_82":83,"_84":24},"version",9,"changes",[19],"aiChatInfo","userId",{"_20":21,"_22":-7,"_23":24,"_25":24,"_26":27,"_28":27},"file",{"_29":30,"_31":27,"_32":33,"_34":35,"_36":37,"_38":14,"_39":40,"_23":24},"previous","deleted",false,"deletedHere","path","semantic_tx_context_probe.ts","latestPath","fileId","31287218-aab0-11f1-8d68-1607ee4eb77e","name","fileType","script","content","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","createdAt",["D",1788780914070],"branchVersion","branchId","2595f4e4-b0cd-44f6-9aa1-6540e43e2542","id","d3d259ed-f70f-4048-b75c-89c5e4b0dabe","brain-chain-fork-lab-0907",["D",1788780278106],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","Disposable epoch2 chain linearization lab","imageUrl","6be0fc5c-1fef-4bd6-a1e1-67a3f8c0764e","pinnedFileId","pinPreview","pinMigrated","screenshotVersion","likeCount",0,"orgId","01a0715b-703f-741f-ab35-c85020e4a5e0","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","user",{"_96":95,"_104":100},"org",{"_96":95,"_97":98,"_99":100,"_18":53,"_101":102,"_103":24},"branch",{"_13":85,"_31":86,"_41":40,"_87":42,"_88":-5,"_89":-5,"_90":-5,"_91":-5,"_92":-5,"_93":43,"_94":95},"isOwned",13,"main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","mosadek","handle","displayName","Mo Sadek","avatar","https://lh3.googleusercontent.com/a/ACg8ocL1eT_LHhKSg5px3nXIO6eez79aZXef466qXKh2gak-0iwrvw=s96-c","tier","free","canRestrictVals","profileImageUrl","branchName","","adoptOrgId",{"_41":42,"_31":43,"_36":187,"_45":-5,"_46":24,"_47":48,"_49":48,"_50":51,"_52":-5,"_18":53,"_54":-5,"_55":24,"_56":-5,"_57":-5,"_58":59,"_60":61,"_62":63,"_64":65,"_66":188,"_68":-5,"_69":70,"_71":70,"_72":73,"_74":73,"_75":73,"_76":70,"_77":70,"_78":189,"_80":190,"_82":191,"_84":24},"tree",[170,171,172,173],"files",[170,171,172,173],"counts",{"_159":59,"_160":161,"_162":59,"_163":164,"_165":166},"contents",[127,128,129,130],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},{"_41":153,"_31":154,"_29":155,"_132":-5,"_39":40,"_38":143,"_133":134,"_36":156,"_13":59,"_32":33,"_34":157,"_23":24,"_136":-5,"_26":158},{"_41":146,"_31":147,"_29":148,"_132":-5,"_39":40,"_38":149,"_133":24,"_36":150,"_13":59,"_32":33,"_34":151,"_23":24,"_136":-5,"_26":152},{"_41":138,"_31":139,"_29":140,"_132":-5,"_39":40,"_38":141,"_133":24,"_36":142,"_13":143,"_32":33,"_34":144,"_23":24,"_136":-5,"_26":145},{"_41":131,"_31":27,"_29":30,"_132":-5,"_39":40,"_38":14,"_133":134,"_36":135,"_13":59,"_32":33,"_34":35,"_23":24,"_136":-5,"_26":137},"12876b57-821d-40e0-8cba-a64aeec41c12","parentId","latest",true,["D",1788780914070],"label",[27],"fce23527-c812-4abc-b32c-5ccdb58b32fb","main.ts","b61e86bc-aaae-11f1-b19b-1607ee4eb77e",7,["D",1788780733832],5,"import { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\n\nconst P=\"forklab_\"+Date.now()+\"_\"+Math.random().toString(16).slice(2,8);\nconst M=P+\"_meta\", E=P+\"_events\";\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(\"\")}\nasync function init(){\n await sqlite.execute(`CREATE TABLE ${M}(id INTEGER PRIMARY KEY, head TEXT NOT NULL, generation INTEGER NOT NULL)`);\n await sqlite.execute(`CREATE TABLE ${E}(seq INTEGER PRIMARY KEY, name TEXT NOT NULL, prev TEXT NOT NULL, hash TEXT NOT NULL)`);\n await sqlite.execute({sql:`INSERT INTO ${M}(id,head,generation) VALUES(1,?,0)`,args:[\"GENESIS\"]});\n}\nasync function row(sql:string,args:any[]=[]){return (await sqlite.execute({sql,args})).rows?.[0] as any}\nasync function chain(){\n const es:any[]=(await sqlite.execute(`SELECT * FROM ${E} ORDER BY seq`)).rows as any[];\n let prev=\"GENESIS\", bad:any[]=[];\n for(const x of es){if(x.prev!==prev)bad.push({seq:x.seq,expected:prev,actual:x.prev});prev=x.hash}\n const m:any=await row(`SELECT * FROM ${M} WHERE id=1`);\n return {ok:bad.length===0&&m.head===prev,bad,computed_head:prev,stored_head:m.head,events:es};\n}\nasync function reset(){\n await sqlite.execute(`DELETE FROM ${E}`);\n await sqlite.execute({sql:`UPDATE ${M} SET head=?,generation=0 WHERE id=1`,args:[\"GENESIS\"]});\n}\nasync function unsafeAppend(name:string,seq:number,barrier:{n:number,go?:()=>void,p:Promise}){\n const m:any=await row(`SELECT * FROM ${M} WHERE id=1`);\n barrier.n++; if(barrier.n===2&&barrier.go)barrier.go();\n await barrier.p;\n const h=await sha(name+\"|\"+m.head+\"|\"+seq);\n await sqlite.execute({sql:`INSERT INTO ${E}(seq,name,prev,hash) VALUES(?,?,?,?)`,args:[seq,name,m.head,h]});\n await sqlite.execute({sql:`UPDATE ${M} SET head=?,generation=generation+1 WHERE id=1`,args:[h]});\n}\nasync function safeAppend(name:string,delayMs=0,throwAfterInsert=false){\n const tx=await sqlite.transaction(\"write\");\n try{\n const m:any=(await tx.execute(`SELECT * FROM ${M} WHERE id=1`)).rows?.[0];\n const seq=Number(((await tx.execute(`SELECT COALESCE(MAX(seq),0)+1 n FROM ${E}`)).rows?.[0] as any).n);\n const h=await sha(name+\"|\"+m.head+\"|\"+seq);\n await tx.execute({sql:`INSERT INTO ${E}(seq,name,prev,hash) VALUES(?,?,?,?)`,args:[seq,name,m.head,h]});\n if(delayMs)await sleep(delayMs);\n if(throwAfterInsert)throw new Error(\"INJECTED_AFTER_EVENT_BEFORE_HEAD\");\n await tx.execute({sql:`UPDATE ${M} SET head=?,generation=generation+1 WHERE id=1 AND head=?`,args:[h,m.head]});\n await tx.commit();\n return {ok:true,seq,h};\n }catch(e){await tx.rollback();return {ok:false,error:e instanceof Error?e.message:String(e)}}\n}\nasync function cleanup(){await sqlite.execute(`DROP TABLE IF EXISTS ${E}`);await sqlite.execute(`DROP TABLE IF EXISTS ${M}`)}\nasync function run(){\n await init();\n const tests:any[]=[];\n let release!:()=>void;const p=new Promise(r=>release=r);const b={n:0,go:release,p};\n await Promise.all([unsafeAppend(\"A\",1,b),unsafeAppend(\"B\",2,b)]);\n let c=await chain();\n tests.push({id:\"UNSAFE_PATTERN_REPRODUCES_SIBLING_FORK\",pass:!c.ok&&c.bad.length===1,observation:c});\n\n await reset();\n const sr=await Promise.all([safeAppend(\"A\",250),safeAppend(\"B\",0)]);\n c=await chain();\n tests.push({id:\"WRITE_TX_SERIALIZES_CONCURRENT_WRITERS\",pass:c.ok&&c.events.length===2,results:sr,observation:c});\n\n await reset();\n const crash=await safeAppend(\"CRASH\",0,true);\n const after=await safeAppend(\"AFTER\",0,false);\n c=await chain();\n tests.push({id:\"WRITE_TX_ROLLS_BACK_EVENT_BEFORE_HEAD_CRASH\",pass:!crash.ok&&after.ok&&c.ok&&c.events.length===1&&c.events[0].name===\"AFTER\",crash,after,observation:c});\n\n await reset();\n const late=Promise.all([safeAppend(\"SLOW_OLD\",700),safeAppend(\"SUCCESSOR\",0)]);\n const lr=await late;c=await chain();\n tests.push({id:\"TRANSACTION_SERIALIZATION_SURVIVES_LATE_OVERLAP\",pass:c.ok&&c.events.length===2,results:lr,observation:c});\n\n const receipt={schema:\"VAL_NATIVE_CHAIN_LINEARIZATION_CLEANROOM_V1\",classification:\"DISPOSABLE_NONAUTHORITY\",tests,passed:tests.filter(x=>x.pass).length,failed:tests.filter(x=>!x.pass).length,repair_implication:\"Canonical state mutation + event append + head/generation updates must share one SQLite write transaction. Transport result fencing alone is insufficient, but late overlap cannot fork the chain when canonical mutations are transaction-serialized.\",direct_sprites_calls:0,human_authority_approval:false};\n await cleanup();\n console.log(JSON.stringify(receipt));\n return receipt;\n}\nawait run();\n",[139],"d25c6806-8d8e-409e-880d-ffb433c2d4f6","command_tx_probe.ts","18044578-aab0-11f1-8062-1607ee4eb77e",8,["D",1788780871878],"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();",[147],"d6818392-354e-4db4-aaa2-560a94c57e72","als_probe.ts","aa741c0e-aaaf-11f1-8f46-1607ee4eb77e",["D",1788780688009],"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",[154],"pulls","branches",1,"forks","envVars",{"_167":59,"_169":59},"connections",{"_167":59,"_168":59},"count","unfilledCount","emptyCount",{"_41":153,"_31":154,"_29":155,"_132":-5,"_39":40,"_38":143,"_133":134,"_36":184,"_13":59,"_32":33,"_34":157,"_23":24,"_136":-5,"_175":185,"_26":186},{"_41":146,"_31":147,"_29":148,"_132":-5,"_39":40,"_38":149,"_133":24,"_36":181,"_13":59,"_32":33,"_34":151,"_23":24,"_136":-5,"_175":182,"_26":183},{"_41":138,"_31":139,"_29":140,"_132":-5,"_39":40,"_38":141,"_133":24,"_36":178,"_13":143,"_32":33,"_34":144,"_23":24,"_136":-5,"_175":179,"_26":180},{"_41":131,"_31":27,"_29":30,"_132":-5,"_39":40,"_38":14,"_133":134,"_36":174,"_13":59,"_32":33,"_34":35,"_23":24,"_136":-5,"_175":176,"_26":177},["D",1788780914070],"children",[],[27],["D",1788780733832],[],[139],["D",1788780871878],[],[147],["D",1788780688009],[],[154],["D",1788780278106],["D",1789476648181],{"_96":95,"_104":100},{"_96":95,"_97":98,"_99":100,"_18":53,"_101":102,"_103":24},{"_13":85,"_31":86,"_41":40,"_87":42,"_88":-5,"_89":-5,"_90":-5,"_91":-5,"_92":-5,"_93":43,"_94":95},"ctx",{"_78":-5,"_124":225,"_226":227,"_228":229,"_230":24,"_231":24,"_232":24,"_233":134,"_234":-5,"_235":-7,"_236":-7,"_237":59,"_238":24,"_239":24,"_240":-5,"_241":24,"_242":24,"_243":24,"_244":-5},"ENV",{"_196":197,"_198":199,"_200":86,"_201":202,"_203":204,"_205":206,"_207":208,"_209":210,"_211":212,"_213":214,"_215":216,"_217":218,"_219":220,"_221":222,"_223":224},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","RENDER_GIT_COMMIT","e87eb04e707cf64e7e532c8e8ec395f209e17f15","RENDER_GIT_BRANCH","POSTHOG_API_TOKEN","phc_nmoyuAkStEZuUp69rYlg1DZgrIt19Gx0Y4Hwf8tGgJP","POSTHOG_API_HOST","https://wart.val.town","WEB_API_TEMPLATE","https://{val}.web.val.run","APP_URL","https://www.val.town","MODULE_URL","https://esm.town","VANITY_WEB_API_TEMPLATE","https://{label}.val.run/","DENOLS_URL","https://lsp.val.town","NODE_ENV","production","CLOUDFLARE_TURNSTILE_SITE_KEY","0x4AAAAAACtaIZJH7s9rBMZ6","GOOGLE_CLIENT_ID","875989696899-jtsqkhlbdv5jrlsk8631p7ipjg3c6o62.apps.googleusercontent.com","STRIPE_PUBLISHABLE_KEY","pk_live_51N2zvWEpZTTLipIkVEwXrUG9AT0yeOOEYxszarZT1jpsZV58Ly6wlg3SltZpHN26CUalOBmUSY7adQRQiSkCZz2500qSXNkf8Y","API_URL","https://api.val.town",[],"preferencesKeybindings","default","preferencesTheme","light","preferencesFixers","preferencesCopilot","preferencesSelectionAi","preferencesCloseBrackets","preferencesChatPanelState","preferencesDprint","preferencesDenofmt","notificationCount","flagDenols","isBusinessOrgMember","businessOrgHandle","isBusinessOrgAdmin","isHigherTownieTier","navCollapsed","currentOrgId"]

Diff · v9