[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_205":206,"_207":208},"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",12,"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","probe_prod_kernel_public_surface_v1.ts","latestPath","fileId","f2ab8c54-aab0-11f1-9403-1607ee4eb77e","name","fileType","script","content","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));","createdAt",["D",1788781238726],"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":200,"_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":201,"_68":-5,"_69":70,"_71":70,"_72":73,"_74":73,"_75":73,"_76":70,"_77":70,"_78":202,"_80":203,"_82":204,"_84":24},"tree",[179,180,181,182,183],"files",[179,180,181,182,183],"counts",{"_169":59,"_170":159,"_171":59,"_172":173,"_174":175},"contents",[127,128,129,130,131],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},{"_41":162,"_31":163,"_29":164,"_135":-5,"_39":40,"_38":165,"_137":138,"_36":166,"_13":59,"_32":33,"_34":167,"_23":24,"_141":-5,"_26":168},{"_41":154,"_31":155,"_29":156,"_135":-5,"_39":40,"_38":157,"_137":138,"_36":158,"_13":159,"_32":33,"_34":160,"_23":24,"_141":-5,"_26":161},{"_41":146,"_31":147,"_29":148,"_135":-5,"_39":40,"_38":149,"_137":138,"_36":150,"_13":151,"_32":33,"_34":152,"_23":24,"_141":-5,"_26":153},{"_41":143,"_31":27,"_29":30,"_135":-5,"_39":40,"_38":14,"_137":138,"_36":144,"_13":59,"_32":33,"_34":35,"_23":24,"_141":-5,"_26":145},{"_41":132,"_31":133,"_29":134,"_135":-5,"_39":40,"_38":136,"_137":138,"_36":139,"_13":59,"_32":33,"_34":140,"_23":24,"_141":-5,"_26":142},"12876b57-821d-40e0-8cba-a64aeec41c12","semantic_tx_context_probe.ts","31287218-aab0-11f1-8d68-1607ee4eb77e","parentId",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","label",[133],"bf354ca1-061b-4001-9e50-93bf00871d8c",["D",1788781238726],[27],"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",[147],"a2cd28d3-0278-4c92-b9cb-5411ed7fda1b","command_tx_probe.ts","18044578-aab0-11f1-8062-1607ee4eb77e",10,["D",1788780987553],1,"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();",[155],"d6818392-354e-4db4-aaa2-560a94c57e72","als_probe.ts","aa741c0e-aaaf-11f1-8f46-1607ee4eb77e",5,["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",[163],"pulls","branches","forks","envVars",{"_176":59,"_178":59},"connections",{"_176":59,"_177":59},"count","unfilledCount","emptyCount",{"_41":162,"_31":163,"_29":164,"_135":-5,"_39":40,"_38":165,"_137":138,"_36":197,"_13":59,"_32":33,"_34":167,"_23":24,"_141":-5,"_185":198,"_26":199},{"_41":154,"_31":155,"_29":156,"_135":-5,"_39":40,"_38":157,"_137":138,"_36":194,"_13":159,"_32":33,"_34":160,"_23":24,"_141":-5,"_185":195,"_26":196},{"_41":146,"_31":147,"_29":148,"_135":-5,"_39":40,"_38":149,"_137":138,"_36":191,"_13":151,"_32":33,"_34":152,"_23":24,"_141":-5,"_185":192,"_26":193},{"_41":143,"_31":27,"_29":30,"_135":-5,"_39":40,"_38":14,"_137":138,"_36":188,"_13":59,"_32":33,"_34":35,"_23":24,"_141":-5,"_185":189,"_26":190},{"_41":132,"_31":133,"_29":134,"_135":-5,"_39":40,"_38":136,"_137":138,"_36":184,"_13":59,"_32":33,"_34":140,"_23":24,"_141":-5,"_185":186,"_26":187},["D",1788780914070],"children",[],[133],["D",1788781238726],[],[27],["D",1788781078667],[],[147],["D",1788780987553],[],[155],["D",1788780688009],[],[163],["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":238,"_239":240,"_241":242,"_243":24,"_244":24,"_245":24,"_246":138,"_247":-5,"_248":-7,"_249":-7,"_250":59,"_251":24,"_252":24,"_253":-5,"_254":24,"_255":24,"_256":24,"_257":-5},"ENV",{"_209":210,"_211":212,"_213":86,"_214":215,"_216":217,"_218":219,"_220":221,"_222":223,"_224":225,"_226":227,"_228":229,"_230":231,"_232":233,"_234":235,"_236":237},"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 · v12