Contact form

\n Submissions are saved to this val's SQLite database.\n

\n \n

\n view submissions\n view source\n

\n \n );\n}\n","label",[159,68],"components","pulls","branches","forks","envVars",{"_167":26,"_169":26},"connections",{"_167":26,"_168":26},"count","unfilledCount","emptyCount",{"_32":395,"_13":159,"_66":151,"_42":-5,"_34":35,"_152":39,"_153":88,"_36":396,"_38":26,"_69":397,"_155":-5,"_71":24,"_157":-5,"_204":398,"_17":399},{"_32":150,"_13":68,"_66":67,"_42":151,"_34":35,"_152":39,"_153":88,"_36":392,"_38":26,"_69":70,"_155":156,"_71":24,"_157":-5,"_204":393,"_17":394},{"_32":385,"_13":386,"_66":387,"_42":151,"_34":35,"_152":39,"_153":88,"_36":388,"_38":26,"_69":70,"_155":389,"_71":24,"_157":-5,"_204":390,"_17":391},{"_32":378,"_13":379,"_66":380,"_42":151,"_34":35,"_152":39,"_153":88,"_36":381,"_38":26,"_69":70,"_155":382,"_71":24,"_157":-5,"_204":383,"_17":384},{"_32":371,"_13":372,"_66":373,"_42":-5,"_34":35,"_152":39,"_153":88,"_36":374,"_38":26,"_69":21,"_155":375,"_71":24,"_157":-5,"_204":376,"_17":377},{"_32":363,"_13":364,"_66":365,"_42":-5,"_34":35,"_152":366,"_153":88,"_36":367,"_38":26,"_69":202,"_155":368,"_71":24,"_157":-5,"_204":369,"_17":370},{"_32":355,"_13":356,"_66":357,"_42":-5,"_34":35,"_152":358,"_153":88,"_36":359,"_38":26,"_69":70,"_155":360,"_71":24,"_157":-5,"_204":361,"_17":362},{"_32":347,"_13":348,"_66":349,"_42":-5,"_34":35,"_152":350,"_153":88,"_36":351,"_38":26,"_69":70,"_155":352,"_71":24,"_157":-5,"_204":353,"_17":354},{"_32":339,"_13":340,"_66":341,"_42":-5,"_34":35,"_152":342,"_153":88,"_36":343,"_38":26,"_69":202,"_155":344,"_71":24,"_157":-5,"_204":345,"_17":346},{"_32":332,"_13":333,"_66":334,"_42":-5,"_34":35,"_152":114,"_153":88,"_36":335,"_38":39,"_69":70,"_155":336,"_71":24,"_157":-5,"_204":337,"_17":338},{"_32":324,"_13":325,"_66":326,"_42":-5,"_34":35,"_152":327,"_153":88,"_36":328,"_38":26,"_69":70,"_155":329,"_71":24,"_157":-5,"_204":330,"_17":331},{"_32":316,"_13":317,"_66":318,"_42":-5,"_34":35,"_152":319,"_153":88,"_36":320,"_38":218,"_69":202,"_155":321,"_71":24,"_157":-5,"_204":322,"_17":323},{"_32":309,"_13":310,"_66":311,"_42":-5,"_34":35,"_152":39,"_153":88,"_36":312,"_38":26,"_69":70,"_155":313,"_71":24,"_157":-5,"_204":314,"_17":315},{"_32":301,"_13":302,"_66":303,"_42":-5,"_34":35,"_152":304,"_153":88,"_36":305,"_38":26,"_69":70,"_155":306,"_71":24,"_157":-5,"_204":307,"_17":308},{"_32":293,"_13":294,"_66":295,"_42":-5,"_34":35,"_152":296,"_153":88,"_36":297,"_38":26,"_69":70,"_155":298,"_71":24,"_157":-5,"_204":299,"_17":300},{"_32":285,"_13":286,"_66":287,"_42":-5,"_34":35,"_152":288,"_153":88,"_36":289,"_38":26,"_69":70,"_155":290,"_71":24,"_157":-5,"_204":291,"_17":292},{"_32":277,"_13":278,"_66":279,"_42":-5,"_34":35,"_152":280,"_153":88,"_36":281,"_38":39,"_69":202,"_155":282,"_71":24,"_157":-5,"_204":283,"_17":284},{"_32":269,"_13":270,"_66":271,"_42":-5,"_34":35,"_152":272,"_153":88,"_36":273,"_38":26,"_69":202,"_155":274,"_71":24,"_157":-5,"_204":275,"_17":276},{"_32":263,"_13":264,"_66":86,"_42":-5,"_34":35,"_152":39,"_153":88,"_36":265,"_38":26,"_69":202,"_155":266,"_71":24,"_157":-5,"_204":267,"_17":268},{"_32":255,"_13":256,"_66":257,"_42":-5,"_34":35,"_152":258,"_153":88,"_36":259,"_38":26,"_69":70,"_155":260,"_71":24,"_157":-5,"_204":261,"_17":262},{"_32":247,"_13":248,"_66":249,"_42":-5,"_34":35,"_152":250,"_153":88,"_36":251,"_38":26,"_69":70,"_155":252,"_71":24,"_157":-5,"_204":253,"_17":254},{"_32":239,"_13":240,"_66":241,"_42":-5,"_34":35,"_152":242,"_153":88,"_36":243,"_38":26,"_69":202,"_155":244,"_71":24,"_157":-5,"_204":245,"_17":246},{"_32":231,"_13":232,"_66":233,"_42":-5,"_34":35,"_152":234,"_153":88,"_36":235,"_38":39,"_69":70,"_155":236,"_71":24,"_157":-5,"_204":237,"_17":238},{"_32":223,"_13":224,"_66":225,"_42":-5,"_34":35,"_152":226,"_153":88,"_36":227,"_38":26,"_69":70,"_155":228,"_71":24,"_157":-5,"_204":229,"_17":230},{"_32":215,"_13":216,"_66":217,"_42":-5,"_34":35,"_152":218,"_153":88,"_36":219,"_38":26,"_69":70,"_155":220,"_71":24,"_157":-5,"_204":221,"_17":222},{"_32":207,"_13":208,"_66":209,"_42":-5,"_34":35,"_152":210,"_153":88,"_36":211,"_38":26,"_69":202,"_155":212,"_71":24,"_157":-5,"_204":213,"_17":214},{"_32":197,"_13":198,"_66":199,"_42":-5,"_34":35,"_152":200,"_153":88,"_36":201,"_38":26,"_69":202,"_155":203,"_71":24,"_157":-5,"_204":205,"_17":206},"08c8c8f2-1251-45d5-b08d-70f87e51aa85","txadm_test_http.ts","b79510b8-aab0-11f1-8b52-1607ee4eb77e",17,["D",1788781139538],"http","import run from \"./transactional_admission_candidate_v1_test.ts\";\nexport default async function(){return Response.json(await run());}","children",[],[198],"f0286eb6-10e1-4b8a-a92b-d114d125e029","txadm_crash_http.ts","e85cdcc6-aab0-11f1-ae0a-1607ee4eb77e",20,["D",1788781221434],"import { initFixture,registerTx,claimTxTimeoutHold,snapshot,verifyChain } from \"./transactional_admission_candidate_v1.ts\";\nexport default async function(req:Request){\n const u=new URL(req.url),action=u.searchParams.get(\"action\")||\"check\";\n if(action===\"init\"){\n await initFixture();await registerTx(\"A\");\n return Response.json({ok:true,action,snapshot:await snapshot(),verify:await verifyChain()});\n }\n if(action===\"hold\"){\n const out=await claimTxTimeoutHold(\"A\",70000);\n return Response.json({ok:true,action,out,snapshot:await snapshot(),verify:await verifyChain()});\n }\n return Response.json({ok:true,action,snapshot:await snapshot(),verify:await verifyChain()});\n}",[],[208],"36a83900-21fc-4ecc-a596-6ea9213f5c7c","tx_probe.ts","cc74516e-a98a-11f1-b61d-1607ee4eb77e",2,["D",1788654902545],"import { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\n\nasync function main() {\n const table = \"c4e7_tx_probe\";\n const out: Record = {\n schema: \"BRAIN_VAL_NATIVE_TX_QUALIFICATION_V1\",\n sqlite_transaction_type: typeof (sqlite as any).transaction,\n pass: false,\n checks: {},\n };\n const checks = out.checks as Record;\n\n await sqlite.execute(`DROP TABLE IF EXISTS ${table}`);\n await sqlite.execute(`CREATE TABLE ${table}(id INTEGER PRIMARY KEY, v INTEGER NOT NULL, note TEXT NOT NULL)`);\n await sqlite.execute({ sql: `INSERT INTO ${table}(id,v,note) VALUES(1,10,'seed')` });\n\n if (typeof (sqlite as any).transaction !== \"function\") {\n checks.transaction_api = \"MISSING\";\n console.log(JSON.stringify(out));\n return;\n }\n checks.transaction_api = \"PRESENT\";\n\n const tx1 = await (sqlite as any).transaction(\"write\");\n const r1 = await tx1.execute(`SELECT v FROM ${table} WHERE id=1`);\n const before = Number((r1.rows[0] as any).v);\n await tx1.execute({ sql: `UPDATE ${table} SET v=?, note='rollback' WHERE id=1`, args: [before + 1] });\n const r2 = await tx1.execute(`SELECT v FROM ${table} WHERE id=1`);\n const insideRollback = Number((r2.rows[0] as any).v);\n await tx1.rollback();\n const r3 = await sqlite.execute(`SELECT v,note FROM ${table} WHERE id=1`);\n const afterRollback = Number((r3.rows[0] as any).v);\n checks.interactive_read_write = before === 10 && insideRollback === 11;\n checks.rollback_isolation = afterRollback === 10 && (r3.rows[0] as any).note === \"seed\";\n\n const tx2 = await (sqlite as any).transaction(\"write\");\n const r4 = await tx2.execute(`SELECT v FROM ${table} WHERE id=1`);\n const dynamicBefore = Number((r4.rows[0] as any).v);\n const upd = await tx2.execute({\n sql: `UPDATE ${table} SET v=?, note='commit' WHERE id=1 AND v=?`,\n args: [dynamicBefore + 5, dynamicBefore],\n });\n await tx2.commit();\n const r5 = await sqlite.execute(`SELECT v,note FROM ${table} WHERE id=1`);\n checks.dynamic_conditional_commit =\n Number((upd as any).rowsAffected) === 1 &&\n Number((r5.rows[0] as any).v) === 15 &&\n (r5.rows[0] as any).note === \"commit\";\n\n const tx3 = await (sqlite as any).transaction(\"write\");\n let constraintCaught = false;\n try {\n await tx3.execute(`UPDATE ${table} SET v=99,note='should-rollback' WHERE id=1`);\n await tx3.execute(`INSERT INTO ${table}(id,v,note) VALUES(1,0,'duplicate')`);\n await tx3.commit();\n } catch (_e) {\n constraintCaught = true;\n try { await tx3.rollback(); } catch { /* already rolled back/closed */ }\n }\n const r6 = await sqlite.execute(`SELECT v,note FROM ${table} WHERE id=1`);\n checks.error_rollback =\n constraintCaught &&\n Number((r6.rows[0] as any).v) === 15 &&\n (r6.rows[0] as any).note === \"commit\";\n\n out.pass = Object.values(checks).every((v) => v === true || v === \"PRESENT\");\n await sqlite.execute(`DROP TABLE IF EXISTS ${table}`);\n console.log(JSON.stringify(out));\n}\n\nawait main();\n",[],[216],"b79d1649-9a4c-4ddf-9b8f-6f19b0623839","transactional_admission_candidate_v1_test.ts","a48684e8-aab0-11f1-bca5-1607ee4eb77e",16,["D",1788781107609],"import { initFixture,registerTx,claimTx,snapshot,verifyChain } from \"./transactional_admission_candidate_v1.ts\";\n\nfunction stable(x:any){return JSON.stringify(x);}\nfunction assert(c:any,m:string){if(!c)throw new Error(m);}\n\nexport default async function(){\n const results:any={register_faults:[],claim_faults:[],success:null,concurrent:null};\n const rf=[\"register_after_agent_insert\",\"register_after_event_insert\",\"register_after_head_update\",\"register_after_generation_bump\",\"register_after_agent_update\",\"register_after_workstream_update\"];\n for(const f of rf){\n await initFixture();const before=stable(await snapshot());let err=\"\";\n try{await registerTx(\"A\",f)}catch(e){err=e instanceof Error?e.message:String(e)}\n const after=stable(await snapshot()),v=await verifyChain();\n assert(err===\"FAULT_\"+f,\"REGISTER_FAULT_NOT_TRIGGERED_\"+f);\n assert(before===after,\"REGISTER_PARTIAL_STATE_\"+f);\n assert(v.ok,\"REGISTER_CHAIN_BAD_\"+f);\n results.register_faults.push({fault:f,rollback_exact:true,chain_ok:true});\n }\n\n const cf=[\"claim_after_task_update\",\"claim_after_event_insert\",\"claim_after_head_update\",\"claim_after_generation_bump\",\"claim_after_agent_update\",\"claim_after_workstream_update\"];\n for(const f of cf){\n await initFixture();await registerTx(\"A\");const before=stable(await snapshot());let err=\"\";\n try{await claimTx(\"A\",f)}catch(e){err=e instanceof Error?e.message:String(e)}\n const after=stable(await snapshot()),v=await verifyChain();\n assert(err===\"FAULT_\"+f,\"CLAIM_FAULT_NOT_TRIGGERED_\"+f);\n assert(before===after,\"CLAIM_PARTIAL_STATE_\"+f);\n assert(v.ok,\"CLAIM_CHAIN_BAD_\"+f);\n results.claim_faults.push({fault:f,rollback_exact:true,chain_ok:true});\n }\n\n await initFixture();const r1=await registerTx(\"A\"),c1=await claimTx(\"A\"),v1=await verifyChain(),s1:any=await snapshot();\n assert(v1.ok&&v1.generation===2&&v1.event_count===2,\"SUCCESS_CHAIN_OR_GEN\");\n assert(s1.tasks[0].state===\"LEASED\"&&s1.tasks[0].lease_owner===\"A\",\"SUCCESS_TASK\");\n results.success={register:r1,claim:c1,verify:v1};\n\n await initFixture();await registerTx(\"A\");await registerTx(\"B\");\n const cc=await Promise.allSettled([claimTx(\"A\"),claimTx(\"B\")]);\n const fulfilled=cc.filter(x=>x.status===\"fulfilled\"),rejected=cc.filter(x=>x.status===\"rejected\");\n const v2=await verifyChain(),s2:any=await snapshot();\n assert(fulfilled.length===1&&rejected.length===1,\"CONCURRENT_CLAIM_CARDINALITY\");\n assert(v2.ok&&v2.generation===3&&v2.event_count===3,\"CONCURRENT_CHAIN_OR_GEN\");\n assert(s2.tasks[0].state===\"LEASED\",\"CONCURRENT_TASK_NOT_LEASED\");\n results.concurrent={outcomes:cc.map((x:any)=>x.status===\"fulfilled\"?{status:x.status,value:x.value}:{status:x.status,reason:String(x.reason?.message||x.reason)}),verify:v2,lease_owner:s2.tasks[0].lease_owner};\n\n const out={ok:true,classification:\"TRANSACTIONAL_ADMISSION_CANDIDATE_V1_PASS\",assertions:rf.length+cf.length+4,results};\n console.log(JSON.stringify(out));\n return out;\n}\n",[],[224],"1f6186fc-50a1-43e2-be09-d81dbc2c3c90","transactional_admission_candidate_v1.ts","a357f408-aab0-11f1-999f-1607ee4eb77e",19,["D",1788781211124],"import { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\n\nconst P=\"c4e7_txadm_\";\nconst GENESIS=\"GENESIS\";\nconst enc=new TextEncoder();\n\nfunction now(){return new Date().toISOString();}\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(db:any,sql:string,args:any[]=[]){const r:any=await db.execute({sql,args});return r.rows?.[0]??null;}\nfunction fault(name:string,at:string){if(name===at)throw new Error(\"FAULT_\"+at);}\n\nexport async function initFixture(){\n for(const t of [\"events\",\"meta\",\"agents\",\"tasks\",\"workstreams\"])await sqlite.execute(`DROP TABLE IF EXISTS ${P}${t}`);\n await sqlite.execute(`CREATE TABLE ${P}meta(id INTEGER PRIMARY KEY,generation INTEGER NOT NULL,event_head_hash TEXT NOT NULL,new_event_count INTEGER NOT NULL)`);\n await sqlite.execute(`CREATE TABLE ${P}events(local_seq INTEGER PRIMARY KEY,event_uuid TEXT NOT NULL,ts TEXT NOT NULL,workstream TEXT NOT NULL,agent_id TEXT,task_id TEXT,type TEXT NOT NULL,payload_json TEXT NOT NULL,prev_hash TEXT NOT NULL,event_hash TEXT NOT NULL,transaction_generation INTEGER NOT NULL)`);\n await sqlite.execute(`CREATE TABLE ${P}agents(id TEXT PRIMARY KEY,status TEXT NOT NULL,boot_generation INTEGER NOT NULL,last_generation INTEGER NOT NULL,last_seen TEXT NOT NULL)`);\n await sqlite.execute(`CREATE TABLE ${P}workstreams(id TEXT PRIMARY KEY,head_generation INTEGER NOT NULL,updated_at TEXT NOT NULL)`);\n await sqlite.execute(`CREATE TABLE ${P}tasks(id TEXT PRIMARY KEY,workstream TEXT NOT NULL,state TEXT NOT NULL,lease_owner TEXT,lease_generation INTEGER,lease_expires_at TEXT,updated_at TEXT NOT NULL)`);\n const t=now();\n await sqlite.execute({sql:`INSERT INTO ${P}meta VALUES(1,0,?,0)`,args:[GENESIS]});\n await sqlite.execute({sql:`INSERT INTO ${P}workstreams VALUES('global',0,?)`,args:[t]});\n await sqlite.execute({sql:`INSERT INTO ${P}tasks VALUES('T1','global','READY',NULL,NULL,NULL,?)`,args:[t]});\n return await snapshot();\n}\n\nasync function appendEventTx(tx:any,ws:string,agent:string|null,task:string|null,type:string,payload:any,prefix:string,faultName:string){\n const m:any=await one(tx,`SELECT generation,event_head_hash FROM ${P}meta WHERE id=1`);\n const seqRow:any=await one(tx,`SELECT COALESCE(MAX(local_seq),0)+1 AS n FROM ${P}events`);\n const seq=Number(seqRow.n),prev=String(m.event_head_hash),ts=now();\n const e={event_uuid:crypto.randomUUID(),ts,workstream:ws,agent_id:agent,task_id:task,type,payload,prev_hash:prev};\n const h=await sha(canon(e));\n await tx.execute({sql:`INSERT INTO ${P}events(local_seq,event_uuid,ts,workstream,agent_id,task_id,type,payload_json,prev_hash,event_hash,transaction_generation) VALUES(?,?,?,?,?,?,?,?,?,?,?)`,\n args:[seq,e.event_uuid,ts,ws,agent,task,type,canon(payload),prev,h,Number(m.generation)]});\n fault(faultName,prefix+\"_after_event_insert\");\n await tx.execute({sql:`UPDATE ${P}meta SET event_head_hash=?,new_event_count=new_event_count+1 WHERE id=1`,args:[h]});\n fault(faultName,prefix+\"_after_head_update\");\n return {seq,event_hash:h};\n}\n\nexport async function registerTx(agent:string,faultName=\"\"){\n const tx:any=await (sqlite as any).transaction(\"write\");\n try{\n const m:any=await one(tx,`SELECT generation FROM ${P}meta WHERE id=1`),g0=Number(m.generation),t=now();\n await tx.execute({sql:`INSERT INTO ${P}agents(id,status,boot_generation,last_generation,last_seen) VALUES(?,'READY',?,?,?)`,args:[agent,g0,g0,t]});\n fault(faultName,\"register_after_agent_insert\");\n await appendEventTx(tx,\"global\",agent,null,\"AGENT_REGISTERED\",{boot_generation:g0},\"register\",faultName);\n const ng=g0+1;\n await tx.execute({sql:`UPDATE ${P}meta SET generation=? WHERE id=1`,args:[ng]});\n fault(faultName,\"register_after_generation_bump\");\n await tx.execute({sql:`UPDATE ${P}agents SET last_generation=?,last_seen=? WHERE id=?`,args:[ng,now(),agent]});\n fault(faultName,\"register_after_agent_update\");\n await tx.execute({sql:`UPDATE ${P}workstreams SET head_generation=?,updated_at=? WHERE id='global'`,args:[ng,now()]});\n fault(faultName,\"register_after_workstream_update\");\n await tx.commit();\n return {ok:true,agent,generation:ng};\n }catch(e){try{await tx.rollback();}catch{}throw e;}\n}\n\nexport async function claimTx(agent:string,faultName=\"\"){\n const tx:any=await (sqlite as any).transaction(\"write\");\n try{\n const ag:any=await one(tx,`SELECT id FROM ${P}agents WHERE id=?`,[agent]);if(!ag)throw new Error(\"UNKNOWN_AGENT\");\n const m:any=await one(tx,`SELECT generation FROM ${P}meta WHERE id=1`),g0=Number(m.generation);\n const exp=new Date(Date.now()+1800_000).toISOString();\n const u:any=await tx.execute({sql:`UPDATE ${P}tasks SET state='LEASED',lease_owner=?,lease_generation=?,lease_expires_at=?,updated_at=? WHERE id='T1' AND state='READY' RETURNING id`,args:[agent,g0,exp,now()]});\n if(!(u.rows||[]).length)throw new Error(\"NO_READY_TASK\");\n fault(faultName,\"claim_after_task_update\");\n await appendEventTx(tx,\"global\",agent,\"T1\",\"TASK_LEASED\",{lease_generation:g0,lease_expires_at:exp},\"claim\",faultName);\n const ng=g0+1;\n await tx.execute({sql:`UPDATE ${P}meta SET generation=? WHERE id=1`,args:[ng]});\n fault(faultName,\"claim_after_generation_bump\");\n await tx.execute({sql:`UPDATE ${P}agents SET status='WORKING',last_generation=?,last_seen=? WHERE id=?`,args:[ng,now(),agent]});\n fault(faultName,\"claim_after_agent_update\");\n await tx.execute({sql:`UPDATE ${P}workstreams SET head_generation=?,updated_at=? WHERE id='global'`,args:[ng,now()]});\n fault(faultName,\"claim_after_workstream_update\");\n await tx.commit();\n return {ok:true,agent,task_id:\"T1\",generation:ng};\n }catch(e){try{await tx.rollback();}catch{}throw e;}\n}\n\nexport async function claimTxTimeoutHold(agent:string,ms=70000){\n const tx:any=await (sqlite as any).transaction(\"write\");\n try{\n const ag:any=await one(tx,`SELECT id FROM ${P}agents WHERE id=?`,[agent]);if(!ag)throw new Error(\"UNKNOWN_AGENT\");\n const m:any=await one(tx,`SELECT generation FROM ${P}meta WHERE id=1`),g0=Number(m.generation);\n const exp=new Date(Date.now()+1800_000).toISOString();\n const u:any=await tx.execute({sql:`UPDATE ${P}tasks SET state='LEASED',lease_owner=?,lease_generation=?,lease_expires_at=?,updated_at=? WHERE id='T1' AND state='READY' RETURNING id`,args:[agent,g0,exp,now()]});\n if(!(u.rows||[]).length)throw new Error(\"NO_READY_TASK\");\n await appendEventTx(tx,\"global\",agent,\"T1\",\"TASK_LEASED\",{lease_generation:g0,lease_expires_at:exp},\"claim\",\"\");\n const ng=g0+1;\n await tx.execute({sql:`UPDATE ${P}meta SET generation=? WHERE id=1`,args:[ng]});\n await tx.execute({sql:`UPDATE ${P}agents SET status='WORKING',last_generation=?,last_seen=? WHERE id=?`,args:[ng,now(),agent]});\n await tx.execute({sql:`UPDATE ${P}workstreams SET head_generation=?,updated_at=? WHERE id='global'`,args:[ng,now()]});\n await new Promise(r=>setTimeout(r,Math.max(61000,Math.min(90000,ms))));\n await tx.commit();\n return {ok:true,agent,task_id:\"T1\",generation:ng,committed_after_hold:true};\n }catch(e){try{await tx.rollback();}catch{}throw e;}\n}\n\nexport async function snapshot(){\n const [m,e,a,t,w]:any[]=await Promise.all([\n sqlite.execute(`SELECT * FROM ${P}meta ORDER BY id`),\n sqlite.execute(`SELECT * FROM ${P}events ORDER BY local_seq`),\n sqlite.execute(`SELECT * FROM ${P}agents ORDER BY id`),\n sqlite.execute(`SELECT * FROM ${P}tasks ORDER BY id`),\n sqlite.execute(`SELECT * FROM ${P}workstreams ORDER BY id`)\n ]);\n return {meta:m.rows||[],events:e.rows||[],agents:a.rows||[],tasks:t.rows||[],workstreams:w.rows||[]};\n}\n\nexport async function verifyChain(){\n const s=await snapshot();const meta:any=s.meta[0];let prev=GENESIS;const bad:number[]=[];\n for(const r of s.events as any[]){\n const payload=JSON.parse(String(r.payload_json));\n const h=await sha(canon({event_uuid:r.event_uuid,ts:r.ts,workstream:r.workstream,agent_id:r.agent_id,task_id:r.task_id,type:r.type,payload,prev_hash:r.prev_hash}));\n if(String(r.prev_hash)!==prev||String(r.event_hash)!==h)bad.push(Number(r.local_seq));\n prev=String(r.event_hash);\n }\n return {ok:bad.length===0&&prev===String(meta.event_head_hash)&&Number(meta.new_event_count)===(s.events as any[]).length,bad,computed_head:prev,stored_head:String(meta.event_head_hash),generation:Number(meta.generation),event_count:(s.events as any[]).length};\n}\n",[],[232],"fb1fbf6c-545d-4f24-b5f0-de36b8565d1a","state_machine_probe.ts","30192e80-a98e-11f1-9774-1607ee4eb77e",9,["D",1788656358233],"import { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\nconst T=\"c4e7_generation_cas\";\nconst sleep=(ms:number)=>new Promise(r=>setTimeout(r,ms));\n\nexport default async function(req:Request):Promise{\n const u=new URL(req.url);\n const action=u.searchParams.get(\"action\")||\"status\";\n if(action===\"init\"){\n await sqlite.execute(`DROP TABLE IF EXISTS ${T}`);\n await sqlite.execute(`CREATE TABLE ${T}(k TEXT PRIMARY KEY,v INTEGER NOT NULL)`);\n await sqlite.execute(`INSERT INTO ${T}(k,v) VALUES('generation',0)`);\n return Response.json({ok:true,action,generation:0});\n }\n if(action===\"cas\"){\n const expected=Number(u.searchParams.get(\"expected\")||\"0\");\n const hold=Math.max(0,Math.min(1000,Number(u.searchParams.get(\"hold\")||\"0\")));\n const tx=await (sqlite as any).transaction(\"write\");\n const start=Date.now();\n const r=await tx.execute(`SELECT v FROM ${T} WHERE k='generation'`);\n const actual=Number((r.rows[0] as any).v);\n const readAt=Date.now();\n if(actual!==expected){\n await tx.rollback();\n return Response.json({ok:false,reason:\"STALE_WRITE\",expected,actual,start,readAt});\n }\n if(hold) await sleep(hold);\n const upd=await tx.execute({sql:`UPDATE ${T} SET v=? WHERE k='generation' AND v=?`,args:[actual+1,actual]});\n if(Number((upd as any).rowsAffected)!==1){\n await tx.rollback();\n return Response.json({ok:false,reason:\"CAS_RACE_LOST\",expected,actual,start,readAt});\n }\n await tx.commit();\n const committed=Date.now();\n return Response.json({ok:true,expected,actual,generation:actual+1,start,readAt,committed});\n }\n if(action===\"orchestrate\"){\n const self=new URL(req.url);\n self.search=\"?action=cas&expected=0&hold=250\";\n const p1=fetch(self).then(async r=>({status:r.status,body:await r.json()}));\n const p2=fetch(self).then(async r=>({status:r.status,body:await r.json()}));\n const [a,b]=await Promise.all([p1,p2]);\n const r=await sqlite.execute(`SELECT v FROM ${T} WHERE k='generation'`);\n const finalGeneration=Number((r.rows[0] as any).v);\n const oks=[a,b].filter((x:any)=>x.body?.ok===true).length;\n const stale=[a,b].filter((x:any)=>x.body?.reason===\"STALE_WRITE\").length;\n return Response.json({ok:oks===1&&stale===1&&finalGeneration===1,action,results:[a,b],final_generation:finalGeneration,successes:oks,stale_rejections:stale});\n }\n const r=await sqlite.execute(`SELECT v FROM ${T} WHERE k='generation'`).catch(()=>({rows:[]}));\n return Response.json({ok:true,action:\"status\",generation:(r.rows[0] as any)?.v??null});\n}",[],[240],"6fb269b6-b30c-4ea4-a934-5b4dcd2ccf59","nonfinite_sqlite_probe.ts","ecec8378-a98d-11f1-94a9-1607ee4eb77e",8,["D",1788656245533],"import { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\nconst table=\"c4e7_nonfinite\";\nawait sqlite.execute(`DROP TABLE IF EXISTS ${table}`);\nawait sqlite.execute(`CREATE TABLE ${table}(name TEXT PRIMARY KEY,x REAL NOT NULL)`);\nconst cases:[string,number][]=[[\"inf\",Infinity],[\"ninf\",-Infinity],[\"nan\",NaN]];\nconst results:any[]=[];\nfor(const [name,x] of cases){\n try{\n await sqlite.execute({sql:`INSERT INTO ${table}(name,x) VALUES(?,?)`,args:[name,x]});\n const r=await sqlite.execute({sql:`SELECT x,typeof(x) AS typ FROM ${table} WHERE name=?`,args:[name]});\n const val=(r.rows[0] as any)?.x;\n results.push({name,inserted:true,returned:String(val),is_finite:Number.isFinite(Number(val)),is_nan:Number.isNaN(Number(val)),typeof_sql:(r.rows[0] as any)?.typ});\n }catch(e){results.push({name,inserted:false,error:String(e)});}\n}\nawait sqlite.execute(`DROP TABLE IF EXISTS ${table}`);\nconsole.log(JSON.stringify({schema:\"BRAIN_VAL_NATIVE_NONFINITE_SQLITE_PROBE_V1\",results}));",[],[248],"34fe831b-411a-45c0-bb9f-01c23ab15833","multiwriter_probe.ts","7d12adf4-a98b-11f1-bf88-1607ee4eb77e",3,["D",1788655198900],"import { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\nconst table=\"c4e7_multiwriter\";\nawait sqlite.execute(`DROP TABLE IF EXISTS ${table}`);\nawait sqlite.execute(`CREATE TABLE ${table}(id INTEGER PRIMARY KEY,v INTEGER NOT NULL)`);\nawait sqlite.execute(`INSERT INTO ${table}(id,v) VALUES(1,0)`);\nconst t0=Date.now();\nconst tx1=await (sqlite as any).transaction(\"write\");\nawait tx1.execute(`UPDATE ${table} SET v=1 WHERE id=1`);\nlet tx2AcquiredAt:number|null=null;\nconst p2=(async()=>{\n const tx2=await (sqlite as any).transaction(\"write\");\n tx2AcquiredAt=Date.now();\n const r=await tx2.execute(`SELECT v FROM ${table} WHERE id=1`);\n const seen=Number((r.rows[0] as any).v);\n await tx2.execute({sql:`UPDATE ${table} SET v=? WHERE id=1`,args:[seen+1]});\n await tx2.commit();\n return {seen};\n})();\nawait new Promise(r=>setTimeout(r,150));\nconst acquiredBeforeCommit=tx2AcquiredAt!==null;\nawait tx1.commit();\nconst tx2Result=await Promise.race([\n p2,\n new Promise((_,rej)=>setTimeout(()=>rej(new Error(\"TX2_TIMEOUT\")),3000))\n]);\nconst finalR=await sqlite.execute(`SELECT v FROM ${table} WHERE id=1`);\nconst finalV=Number((finalR.rows[0] as any).v);\nawait sqlite.execute(`DROP TABLE IF EXISTS ${table}`);\nconsole.log(JSON.stringify({\n schema:\"BRAIN_VAL_NATIVE_MULTIWRITER_QUALIFICATION_V1\",\n pass:!acquiredBeforeCommit&&(tx2Result as any).seen===1&&finalV===2,\n tx2_acquired_before_tx1_commit:acquiredBeforeCommit,\n tx2_seen_value:(tx2Result as any).seen,\n final_value:finalV,\n tx2_acquire_delay_ms:(tx2AcquiredAt??Date.now())-t0\n}));",[],[256],"14ed252d-1580-4166-9548-2f07106fa89c","main.tsx",["D",1788654882934],"/** @jsxImportSource npm:hono/jsx */\nimport { parseVal } from \"https://esm.town/v/std/utils/index.ts\";\nimport { Hono } from \"npm:hono\";\nimport FormPage from \"./components/FormPage.tsx\";\nimport SubmissionsPage from \"./components/SubmissionsPage.tsx\";\nimport { addSubmission, listSubmissions } from \"./db.ts\";\n\nconst app = new Hono();\n\napp.get(\"/\", (c) => c.html());\n\napp.post(\"/submit\", async (c) => {\n const form = await c.req.formData();\n const name = String(form.get(\"name\") ?? \"\").trim();\n const email = String(form.get(\"email\") ?? \"\").trim();\n const message = String(form.get(\"message\") ?? \"\").trim();\n if (!name || !email || !message) {\n return c.text(\"Name, email, and message are all required.\", 400);\n }\n await addSubmission(name, email, message);\n return c.redirect(\"/submissions\");\n});\n\napp.get(\"/submissions\", async (c) => {\n const submissions = await listSubmissions();\n return c.html();\n});\n\napp.get(\"/source\", (c) => c.redirect(parseVal().links.self.val));\n\napp.onError((err) => Promise.reject(err));\n\nexport default app.fetch;\n",[],[264],"675d82cc-9c1f-49ca-a040-3776a17a97c8","m7q4_transport_unknown_outcome_probe.ts","4a3eefc4-aab1-11f1-9465-1607ee4eb77e",21,["D",1788781385656],"import { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\nconst P=\"m7q4_unknown_\";\nfunction now(){return new Date().toISOString();}\nasync function one(db:any,sql:string,args:any[]=[]){const r:any=await db.execute({sql,args});return r.rows?.[0]??null;}\nasync function init(){\n for(const t of [\"meta\",\"tasks\",\"agents\",\"events\"])await sqlite.execute(`DROP TABLE IF EXISTS ${P}${t}`);\n await sqlite.execute(`CREATE TABLE ${P}meta(id INTEGER PRIMARY KEY,generation INTEGER NOT NULL,head TEXT NOT NULL,event_count INTEGER NOT NULL)`);\n await sqlite.execute(`CREATE TABLE ${P}tasks(id TEXT PRIMARY KEY,state TEXT NOT NULL,lease_owner TEXT,lease_generation INTEGER)`);\n await sqlite.execute(`CREATE TABLE ${P}agents(id TEXT PRIMARY KEY,status TEXT NOT NULL)`);\n await sqlite.execute(`CREATE TABLE ${P}events(seq INTEGER PRIMARY KEY,type TEXT NOT NULL,prev TEXT NOT NULL,hash TEXT NOT NULL)`);\n await sqlite.execute(`INSERT INTO ${P}meta VALUES(1,1,'H1',0)`);\n await sqlite.execute(`INSERT INTO ${P}tasks VALUES('T','READY',NULL,NULL)`);\n await sqlite.execute(`INSERT INTO ${P}agents VALUES('A','READY')`);\n return state();\n}\nasync function state(){\n const rs=await Promise.all([\n sqlite.execute(`SELECT * FROM ${P}meta`),sqlite.execute(`SELECT * FROM ${P}tasks`),\n sqlite.execute(`SELECT * FROM ${P}agents`),sqlite.execute(`SELECT * FROM ${P}events ORDER BY seq`)\n ]);\n return {meta:rs[0].rows||[],tasks:rs[1].rows||[],agents:rs[2].rows||[],events:rs[3].rows||[]};\n}\nasync function hold(ms:number){\n const tx:any=await sqlite.transaction(\"write\");\n try{\n const m:any=await one(tx,`SELECT * FROM ${P}meta WHERE id=1`),g=Number(m.generation),prev=String(m.head);\n const u:any=await tx.execute({sql:`UPDATE ${P}tasks SET state='LEASED',lease_owner='A',lease_generation=? WHERE id='T' AND state='READY' RETURNING id`,args:[g]});\n if(!(u.rows||[]).length)throw new Error(\"NO_READY_TASK\");\n await tx.execute(`INSERT INTO ${P}events VALUES(1,'TASK_LEASED','${prev}','H2')`);\n await tx.execute(`UPDATE ${P}meta SET generation=generation+1,head='H2',event_count=event_count+1 WHERE id=1`);\n await tx.execute(`UPDATE ${P}agents SET status='WORKING' WHERE id='A'`);\n await new Promise(r=>setTimeout(r,ms));\n await tx.commit();\n return {ok:true,committed:true,held_ms:ms};\n }catch(e){try{await tx.rollback();}catch{}throw e;}\n}\nexport default async function(req:Request){\n const u=new URL(req.url),a=u.searchParams.get(\"action\")||\"state\";\n if(a===\"init\")return Response.json({ok:true,action:a,state:await init()});\n if(a===\"hold\")return Response.json({ok:true,action:a,result:await hold(Number(u.searchParams.get(\"ms\")||55000)),state:await state()});\n return Response.json({ok:true,action:a,state:await state()});\n}",[],[270],"cb743a10-66ab-487c-b8ce-27ce91655742","independent_atomicity_1330.ts","2d23cf14-aab0-11f1-96fc-1607ee4eb77e",18,["D",1788781152570],"import { sqlite as rootSqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\nimport { AsyncLocalStorage } from \"node:async_hooks\";\nconst txContext=new AsyncLocalStorage();\nconst sqlite:any={\n execute:(...args:any[])=>{const db=txContext.getStore()??rootSqlite;return db.execute(...args)},\n batch:(...args:any[])=>{const db=txContext.getStore()??rootSqlite;return db.batch(...args)}\n};\nasync function withTransaction(fn:()=>Promise):Promise{\n if(txContext.getStore())return await fn();\n const tx:any=await (rootSqlite as any).transaction(\"write\");\n try{const out=await txContext.run(tx,fn);await tx.commit();return out}\n catch(e){try{await tx.rollback()}catch{};throw e}\n}\nconst A=\"independent_atomicity_1330_meta\",B=\"independent_atomicity_1330_task\",E=\"independent_atomicity_1330_events\";\nasync function reset(){\n await rootSqlite.execute(`DROP TABLE IF EXISTS ${E}`);await rootSqlite.execute(`DROP TABLE IF EXISTS ${B}`);await rootSqlite.execute(`DROP TABLE IF EXISTS ${A}`);\n await rootSqlite.execute(`CREATE TABLE ${A}(id INTEGER PRIMARY KEY,generation INTEGER,head TEXT)`);\n await rootSqlite.execute(`CREATE TABLE ${B}(id TEXT PRIMARY KEY,state TEXT,owner TEXT)`);\n await rootSqlite.execute(`CREATE TABLE ${E}(seq INTEGER PRIMARY KEY,type TEXT,prev TEXT,hash TEXT)`);\n await rootSqlite.execute(`INSERT INTO ${A} VALUES(1,0,'h0')`);await rootSqlite.execute(`INSERT INTO ${B} VALUES('t','READY',NULL)`);\n}\nasync function state(){return {meta:(await rootSqlite.execute(`SELECT * FROM ${A}`)).rows,task:(await rootSqlite.execute(`SELECT * FROM ${B}`)).rows,events:(await rootSqlite.execute(`SELECT * FROM ${E} ORDER BY seq`)).rows}}\nasync function command(failAt:string|null){\n return await withTransaction(async()=>{\n await sqlite.execute(`UPDATE ${B} SET state='LEASED',owner='a' WHERE id='t'`);\n if(failAt===\"after_task\")throw new Error(\"FAIL_AFTER_TASK\");\n await sqlite.execute(`INSERT INTO ${E} VALUES(1,'TASK_LEASED','h0','h1')`);\n if(failAt===\"after_event\")throw new Error(\"FAIL_AFTER_EVENT\");\n await sqlite.execute(`UPDATE ${A} SET generation=1,head='h1' WHERE id=1`);\n if(failAt===\"after_meta\")throw new Error(\"FAIL_AFTER_META\");\n return {ok:true};\n });\n}\nexport default async function(req:Request){\n const u=new URL(req.url),mode=u.searchParams.get(\"mode\")||\"state\";\n if(mode===\"reset\"){await reset();return Response.json({ok:true,state:await state()})}\n if(mode===\"state\")return Response.json(await state());\n if(mode===\"success\"){const out=await command(null);return Response.json({out,state:await state()})}\n if(mode.startsWith(\"fail_\")){const at=mode.slice(5);try{await command(at);return Response.json({unexpected:true,state:await state()})}catch(e){return Response.json({caught:e instanceof Error?e.message:String(e),state:await state()})}}\n return new Response(\"bad mode\",{status:400});\n}",[],[278],"49334ef3-31f4-4ba0-ae32-78a9ac00fd53","float_surface_probe.ts","a207f996-a98d-11f1-a18f-1607ee4eb77e",7,["D",1788656119898],"const vals=[\n 0,-0,1,-1,10,103.055,1e-7,1e-6,1e-5,1e15,1e16,1e20,1e21,\n 1.2345678901234567,1.0000000000000002,1.2e30,1.2e-30,5e-324,2.2250738585072014e-308\n];\nconsole.log(JSON.stringify(vals.map(v=>({v:String(v),json:JSON.stringify(v),negzero:Object.is(v,-0)}))));",[],[286],"f7a07af1-c185-40d3-9b85-625c1516c51c","extart_replay_x4n7.ts","9d1a3c38-aa1d-11f1-8a61-1607ee4eb77e",11,["D",1788717959158],"import { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\nimport { recoverExpiredSql, resultSql } from \"https://esm.town/v/mosadek/project-brain-live-v1-durable/brain_bridge_worker.ts\";\n\nconst KERNEL_URL=\"https://mosadek--dbb28a32aa1c11f1b0d41607ee4eb77e.web.val.run\";\nconst KERNEL_SHA=\"8f463c630e7c3836c767ec0feea7d40bd774a10bb5f60a193bc5bbd4d9b1ed9c\";\nconst P=\"x4n7_extart_\";\nconst enc=new TextEncoder();\nfunction hex(a:ArrayBuffer){return [...new Uint8Array(a)].map(x=>x.toString(16).padStart(2,\"0\")).join(\"\")}\nfunction assert(c:any,m:string){if(!c)throw new Error(\"ASSERT:\"+m)}\nasync function q(sql:string,args:any[]=[]){return await sqlite.execute({sql,args})}\n\nconst kr=await fetch(KERNEL_URL); assert(kr.ok,\"kernel fetch\");\nconst kernel=await kr.text();\nconst kb=enc.encode(kernel);\nconst kh=hex(await crypto.subtle.digest(\"SHA-256\",kb));\nassert(kh===KERNEL_SHA,\"kernel sha\");\nassert(kb.byteLength===75648,\"kernel size\");\nconst a=kernel.indexOf(\"def record_external_artifact(args):\");\nconst b=kernel.indexOf(\"\\ndef set_verified_state\",a);\nassert(a>=0&&b>a,\"kernel function extraction\");\nconst fn=kernel.slice(a,b);\nfor(const needle of [\n \"INSERT OR IGNORE INTO artifacts\",\n 'event(c,args.workstream,args.agent,args.task,\"EXTERNAL_ARTIFACT_RECORDED\"',\n \"g=bump(c); c.execute(\\\"UPDATE workstreams SET head_generation=?,updated_at=? WHERE id=?\\\"\"\n]) assert(fn.includes(needle),\"kernel semantic \"+needle);\n\nconst liveRecover=String(recoverExpiredSql(P+\"jobs\"));\nconst liveResult=String(resultSql(P+\"jobs\"));\nassert(liveRecover.includes(\"SET state='READY'\"),\"live recovery requeues\");\nassert(liveRecover.includes(\"WHERE state='LEASED'\"),\"live recovery leased\");\nassert(!/attempt/i.test(liveResult),\"live result has no attempt fence\");\n\nfor(const t of [\"artifacts\",\"events\",\"meta\",\"workstreams\",\"jobs\",\"jobs_fix\"]) await q(\"DROP TABLE IF EXISTS \"+P+t);\nawait q(\"CREATE TABLE \"+P+\"artifacts(sha256 TEXT PRIMARY KEY,size INTEGER,logical_name TEXT,producer_agent TEXT,task_id TEXT,storage_json TEXT,created_at TEXT)\");\nawait q(\"CREATE TABLE \"+P+\"events(id INTEGER PRIMARY KEY AUTOINCREMENT,workstream TEXT,agent_id TEXT,task_id TEXT,type TEXT,payload_json TEXT)\");\nawait q(\"CREATE TABLE \"+P+\"meta(key TEXT PRIMARY KEY,value TEXT)\");\nawait q(\"CREATE TABLE \"+P+\"workstreams(id TEXT PRIMARY KEY,head_generation INTEGER)\");\nawait q(\"CREATE TABLE \"+P+\"jobs(id TEXT PRIMARY KEY,op TEXT,payload_json TEXT,priority REAL,state TEXT,lease_owner TEXT,lease_expires_at TEXT,result_json TEXT,error_json TEXT,created_at TEXT,updated_at TEXT)\");\nawait q(\"INSERT INTO \"+P+\"meta(key,value) VALUES('generation','100')\");\nawait q(\"INSERT INTO \"+P+\"workstreams(id,head_generation) VALUES('global',100)\");\nconst SHA=\"8718e60e2fbfb6003dbd60f290d263a6a33dfed892754f9b0421021fb290f586\";\nconst URI=\"valblob:mosadek/project-brain-live-v1-durable/evidence/brain_bridge_external_artifact/r9k4_registration_probe_v1.json\";\nawait q(\"INSERT INTO \"+P+\"jobs(id,op,payload_json,priority,state,lease_owner,lease_expires_at,created_at,updated_at) VALUES(?,?,?,?,?,?,?,?,?)\",\n [\"J\",\"brain\",\"{}\",1,\"LEASED\",\"W\",\"2000-01-01 00:00:00\",\"1999-01-01 00:00:00\",\"1999-01-01 00:00:00\"]);\nasync function record(){\n await q(\"INSERT OR IGNORE INTO \"+P+\"artifacts(sha256,size,logical_name,producer_agent,task_id,storage_json,created_at) VALUES(?,?,?,?,?,?,datetime('now'))\",\n [SHA,137,\"probe.json\",\"A\",\"T\",JSON.stringify([URI])]);\n await q(\"INSERT INTO \"+P+\"events(workstream,agent_id,task_id,type,payload_json) VALUES(?,?,?,?,?)\",\n [\"global\",\"A\",\"T\",\"EXTERNAL_ARTIFACT_RECORDED\",JSON.stringify({sha256:SHA,size:137,logical_name:\"probe.json\",storage:[URI]})]);\n await q(\"UPDATE \"+P+\"meta SET value=CAST(value AS INTEGER)+1 WHERE key='generation'\");\n const g=Number((await q(\"SELECT value FROM \"+P+\"meta WHERE key='generation'\")).rows?.[0]?.value);\n await q(\"UPDATE \"+P+\"workstreams SET head_generation=? WHERE id='global'\",[g]);\n return g;\n}\nconst g1=await record(); // canonical success, transport result deliberately lost\nawait q(liveRecover); // exact live bridge recovery semantics\nconst afterRecover=(await q(\"SELECT state FROM \"+P+\"jobs WHERE id='J'\")).rows?.[0]?.state;\nassert(afterRecover===\"READY\",\"lost-result job requeued\");\nawait q(\"UPDATE \"+P+\"jobs SET state='LEASED',lease_owner='W',lease_expires_at='2999-01-01 00:00:00' WHERE id='J'\");\nconst g2=await record(); // retry executes canonical mutation again\nconst raw={\n artifacts:Number((await q(\"SELECT count(*) c FROM \"+P+\"artifacts\")).rows?.[0]?.c),\n events:Number((await q(\"SELECT count(*) c FROM \"+P+\"events WHERE type='EXTERNAL_ARTIFACT_RECORDED'\")).rows?.[0]?.c),\n generation:Number((await q(\"SELECT value FROM \"+P+\"meta WHERE key='generation'\")).rows?.[0]?.value),\n head:Number((await q(\"SELECT head_generation FROM \"+P+\"workstreams WHERE id='global'\")).rows?.[0]?.head_generation),\n g1,g2\n};\nassert(raw.artifacts===1,\"row dedupe\");\nassert(raw.events===2,\"duplicate event\");\nassert(raw.generation===102&&raw.head===102,\"double generation mutation\");\n\n// Minimal bridge-only composition model: mutation expiry -> durable UNKNOWN_OUTCOME, safe read expiry -> READY,\n// known-not-executed -> READY, and exact attempt fences result acceptance.\nawait q(\"CREATE TABLE \"+P+\"jobs_fix(id TEXT PRIMARY KEY,state TEXT,kind TEXT,handed_off INTEGER,attempts INTEGER,lease_owner TEXT,lease_expires_at TEXT,retry_permit INTEGER DEFAULT 0,reconcile TEXT)\");\nfor(const row of [\n [\"M\",\"LEASED\",\"MUTATION\",1,1,\"W\",\"2000-01-01 00:00:00\",0,null],\n [\"R\",\"LEASED\",\"READ_ONLY\",1,1,\"W\",\"2000-01-01 00:00:00\",0,null],\n [\"N\",\"LEASED\",\"MUTATION\",0,1,\"W\",\"2000-01-01 00:00:00\",0,null]\n]) await q(\"INSERT INTO \"+P+\"jobs_fix VALUES(?,?,?,?,?,?,?,?,?)\",row);\nawait q(\"UPDATE \"+P+\"jobs_fix SET state='READY',lease_owner=NULL,lease_expires_at=NULL WHERE state='LEASED' AND lease_expires_at[x.id,x.state]));\nassert(states.M===\"UNKNOWN_OUTCOME\",\"mutation quarantine\");\nassert(states.R===\"READY\",\"read recovery preserved\");\nassert(states.N===\"READY\",\"known-not-executed recovery preserved\");\n\n// No retry while UNKNOWN. A proof of NO_EFFECT + one-time permit moves it to READY; changed/mixed remains UNKNOWN.\nlet changed=await q(\"UPDATE \"+P+\"jobs_fix SET state='READY',retry_permit=0 WHERE id='M' AND state='UNKNOWN_OUTCOME' AND reconcile='PROVEN_NO_EFFECT' AND retry_permit=1 RETURNING id\");\nassert((changed.rows||[]).length===0,\"unknown cannot retry without reconcile\");\nawait q(\"UPDATE \"+P+\"jobs_fix SET reconcile='PROVEN_NO_EFFECT',retry_permit=1 WHERE id='M'\");\nchanged=await q(\"UPDATE \"+P+\"jobs_fix SET state='READY',retry_permit=0 WHERE id='M' AND state='UNKNOWN_OUTCOME' AND reconcile='PROVEN_NO_EFFECT' AND retry_permit=1 RETURNING id\");\nassert((changed.rows||[]).length===1,\"one-time reconciled retry\");\nchanged=await q(\"UPDATE \"+P+\"jobs_fix SET state='READY',retry_permit=0 WHERE id='M' AND state='UNKNOWN_OUTCOME' AND reconcile='PROVEN_NO_EFFECT' AND retry_permit=1 RETURNING id\");\nassert((changed.rows||[]).length===0,\"permit consumed\");\n\n// Attempt fencing model: stale attempt 1 cannot complete current lease attempt 2.\nawait q(\"UPDATE \"+P+\"jobs_fix SET state='LEASED',attempts=2,lease_owner='W',lease_expires_at='2999-01-01 00:00:00' WHERE id='M'\");\nconst stale=await q(\"UPDATE \"+P+\"jobs_fix SET state='COMPLETE' WHERE id='M' AND state='LEASED' AND lease_owner='W' AND attempts=? RETURNING id\",[1]);\nassert((stale.rows||[]).length===0,\"stale attempt rejected\");\nconst current=await q(\"UPDATE \"+P+\"jobs_fix SET state='COMPLETE' WHERE id='M' AND state='LEASED' AND lease_owner='W' AND attempts=? RETURNING id\",[2]);\nassert((current.rows||[]).length===1,\"current attempt accepted\");\n\nconsole.log(JSON.stringify({\n ok:true,\n classification:\"EXTERNAL_ARTIFACT_UNKNOWN_OUTCOME_REPLAY_REPRODUCED\",\n kernel:{sha256:kh,size:kb.byteLength,function_sha256:hex(await crypto.subtle.digest(\"SHA-256\",enc.encode(fn)))},\n live_bridge:{recover_sql:liveRecover,result_sql:liveResult},\n counterexample:raw,\n repair_model:{states_after_expiry:states,stale_attempt_rows:(stale.rows||[]).length,current_attempt_rows:(current.rows||[]).length,known_not_executed_recovered:true,read_only_recovered:true,mutation_auto_replay:false},\n production_mutation:false,\n canonical_brain_py_mutation:false,\n direct_sprites:false,\n human_authority_approval:false\n},null,2));",[],[294],"7b5d86c0-19fc-4132-b4d0-3ab13aef1add","epoch2_command_atomicity_claim_probe_1319.ts","1794d6a2-aab0-11f1-8819-1607ee4eb77e",13,["D",1788780871158],"import { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\n\nconst P=\"p0r1319_\";\nconst T=P+\"task\", A=P+\"agent\", W=P+\"ws\", M=P+\"meta\", E=P+\"events\";\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(\"\")}\nfunction canon(x:any):string{if(x===null||typeof x!==\"object\")return JSON.stringify(x);if(Array.isArray(x))return \"[\"+x.map(canon).join(\",\")+\"]\";return \"{\"+Object.keys(x).sort().map(k=>JSON.stringify(k)+\":\"+canon(x[k])).join(\",\")+\"}\"}\nconst baseline={task_state:\"READY\",task_owner:null,agent_status:\"READY\",agent_last_generation:7,ws_head:7,generation:7,event_count:0,event_head:\"H7\"};\n\nasync function init(){\n for(const t of [E,T,A,W,M]) await sqlite.execute(`DROP TABLE IF EXISTS ${t}`);\n await sqlite.execute(`CREATE TABLE ${M}(id INTEGER PRIMARY KEY,generation INTEGER NOT NULL,event_head TEXT NOT NULL,event_count INTEGER NOT NULL)`);\n await sqlite.execute(`CREATE TABLE ${T}(id TEXT PRIMARY KEY,state TEXT NOT NULL,lease_owner TEXT,lease_generation INTEGER,lease_expires_at 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(`CREATE TABLE ${E}(seq INTEGER PRIMARY KEY,prev_hash TEXT NOT NULL,event_hash TEXT NOT NULL,payload TEXT NOT NULL,tx_generation INTEGER NOT NULL)`);\n await sqlite.execute(`INSERT INTO ${M} VALUES(1,7,'H7',0)`);\n await sqlite.execute(`INSERT INTO ${T} VALUES('T','READY',NULL,NULL,NULL)`);\n await sqlite.execute(`INSERT INTO ${A} VALUES('AG','READY',7)`);\n await sqlite.execute(`INSERT INTO ${W} VALUES('global',7)`);\n}\nasync function snap(){\n const m:any=(await sqlite.execute(`SELECT * FROM ${M}`)).rows[0];\n const t:any=(await sqlite.execute(`SELECT * FROM ${T}`)).rows[0];\n const a:any=(await sqlite.execute(`SELECT * FROM ${A}`)).rows[0];\n const w:any=(await sqlite.execute(`SELECT * FROM ${W}`)).rows[0];\n const e:any=(await sqlite.execute(`SELECT COUNT(*) n FROM ${E}`)).rows[0];\n return {task_state:t.state,task_owner:t.lease_owner,agent_status:a.status,agent_last_generation:Number(a.last_generation),ws_head:Number(w.head_generation),generation:Number(m.generation),event_count:Number(e.n),event_head:m.event_head};\n}\nfunction isBaseline(x:any){return JSON.stringify(x)===JSON.stringify(baseline)}\nasync function eventHash(prev:string,payload:any){return await sha(canon({prev_hash:prev,payload}))}\n\nasync function legacyClaim(failAfter:number){\n await init();\n const exp=\"2099-01-01T00:00:00+00:00\"; const g=7;\n try{\n await sqlite.execute({sql:`UPDATE ${T} SET state='LEASED',lease_owner='AG',lease_generation=?,lease_expires_at=? WHERE id='T'`,args:[g,exp]});\n if(failAfter===1)throw new Error(\"INJECT_1\");\n const h=await eventHash(\"H7\",{type:\"TASK_LEASED\",task:\"T\",agent:\"AG\",g});\n await sqlite.execute({sql:`INSERT INTO ${E}(seq,prev_hash,event_hash,payload,tx_generation) VALUES(1,'H7',?,?,?)`,args:[h,'{\"type\":\"TASK_LEASED\"}',g]});\n if(failAfter===2)throw new Error(\"INJECT_2\");\n await sqlite.execute({sql:`UPDATE ${M} SET event_head=?,event_count=event_count+1 WHERE id=1`,args:[h]});\n if(failAfter===3)throw new Error(\"INJECT_3\");\n await sqlite.execute(`UPDATE ${M} SET generation=generation+1 WHERE id=1`);\n if(failAfter===4)throw new Error(\"INJECT_4\");\n await sqlite.execute(`UPDATE ${A} SET status='WORKING',last_generation=8 WHERE id='AG'`);\n if(failAfter===5)throw new Error(\"INJECT_5\");\n await sqlite.execute(`UPDATE ${W} SET head_generation=8 WHERE id='global'`);\n }catch{}\n return await snap();\n}\n\nasync function txClaim(failAfter:number|null){\n await init();\n const exp=\"2099-01-01T00:00:00+00:00\";\n const tx:any=await (sqlite as any).transaction(\"write\");\n try{\n const mr:any=await tx.execute(`SELECT generation,event_head,event_count FROM ${M} WHERE id=1`);\n const g=Number(mr.rows[0].generation),prev=String(mr.rows[0].event_head);\n if(g!==7||prev!==\"H7\")throw new Error(\"STALE_BASE\");\n const u:any=await tx.execute({sql:`UPDATE ${T} SET state='LEASED',lease_owner='AG',lease_generation=?,lease_expires_at=? WHERE id='T' AND state='READY' RETURNING id`,args:[g,exp]});\n if(!(u.rows||[]).length)throw new Error(\"CLAIM_RACE\");\n if(failAfter===1)throw new Error(\"INJECT_1\");\n const h=await eventHash(prev,{type:\"TASK_LEASED\",task:\"T\",agent:\"AG\",g});\n await tx.execute({sql:`INSERT INTO ${E}(seq,prev_hash,event_hash,payload,tx_generation) VALUES(1,?,?,?,?)`,args:[prev,h,'{\"type\":\"TASK_LEASED\"}',g]});\n if(failAfter===2)throw new Error(\"INJECT_2\");\n const hu:any=await tx.execute({sql:`UPDATE ${M} SET event_head=?,event_count=event_count+1 WHERE id=1 AND generation=? AND event_head=? RETURNING id`,args:[h,g,prev]});\n if(!(hu.rows||[]).length)throw new Error(\"HEAD_CAS\");\n if(failAfter===3)throw new Error(\"INJECT_3\");\n const bg:any=await tx.execute({sql:`UPDATE ${M} SET generation=generation+1 WHERE id=1 AND generation=? RETURNING generation`,args:[g]});\n if(!(bg.rows||[]).length)throw new Error(\"GEN_CAS\");\n const ng=Number(bg.rows[0].generation);\n if(failAfter===4)throw new Error(\"INJECT_4\");\n await tx.execute({sql:`UPDATE ${A} SET status='WORKING',last_generation=? WHERE id='AG'`,args:[ng]});\n if(failAfter===5)throw new Error(\"INJECT_5\");\n await tx.execute({sql:`UPDATE ${W} SET head_generation=? WHERE id='global'`,args:[ng]});\n if(failAfter===6)throw new Error(\"INJECT_6\");\n await tx.commit();\n }catch(e){\n try{await tx.rollback()}catch{}\n }\n return await snap();\n}\n\nconst legacy:any[]=[];\nfor(let i=1;i<=5;i++){const s=await legacyClaim(i);legacy.push({fail_after:i,state:s,partial_durable:!isBaseline(s)})}\nconst atomic:any[]=[];\nfor(let i=1;i<=6;i++){const s=await txClaim(i);atomic.push({fail_after:i,state:s,rolled_back_exactly:isBaseline(s)})}\nconst committed=await txClaim(null);\nconst commitOk=committed.task_state===\"LEASED\"&&committed.task_owner===\"AG\"&&committed.agent_status===\"WORKING\"&&committed.agent_last_generation===8&&committed.ws_head===8&&committed.generation===8&&committed.event_count===1&&committed.event_head!==\"H7\";\nconst pass=legacy.every(x=>x.partial_durable)&&atomic.every(x=>x.rolled_back_exactly)&&commitOk;\nconsole.log(JSON.stringify({\n schema:\"BRAIN_EPOCH2_COMMAND_ATOMICITY_CLAIM_BOUNDARY_PROBE_V1\",\n classification:\"NONAUTHORITY_DISPOSABLE_EXECUTABLE_EVIDENCE\",\n production_mutation:false,direct_sprites:false,human_authority_approval:false,\n legacy_control:legacy,\n transaction_candidate:atomic,\n positive_commit:{state:committed,pass:commitOk},\n verdict:pass?\"PASS_COMMAND_WIDE_TRANSACTION_PATTERN_FOR_CLAIM\":\"FAIL\",\n bounded_nonclaim:\"This proves the explicit transaction pattern for the modeled claim write set. It does not by itself prove every production mutator until each is migrated and fault-injected.\",\n pass\n},null,2));",[],[302],"5e399f6f-d7fd-4efa-abe5-347091198811","db.ts","01a07423-90d5-70c6-8557-5e397ecfed8e",["D",1788654882934],"import { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\n\nexport interface Submission {\n id: number;\n name: string;\n email: string;\n message: string;\n created_at: string;\n}\n\nawait sqlite.execute(`CREATE TABLE IF NOT EXISTS submissions (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n name TEXT NOT NULL,\n email TEXT NOT NULL,\n message TEXT NOT NULL,\n created_at TEXT NOT NULL DEFAULT (datetime('now'))\n)`);\n\nexport async function addSubmission(name: string, email: string, message: string) {\n await sqlite.execute({\n sql: \"INSERT INTO submissions (name, email, message) VALUES (?, ?, ?)\",\n args: [name, email, message],\n });\n}\n\nexport async function listSubmissions(): Promise {\n const result = await sqlite.execute(\n \"SELECT id, name, email, message, created_at FROM submissions ORDER BY id DESC\",\n );\n return result.rows as unknown as Submission[];\n}\n",[],[310],"93a9ada8-e07d-421c-90c6-02d2ddd4081d","cross_invocation_probe.ts","1adc412a-a98d-11f1-8795-1607ee4eb77e",6,["D",1788655979040],"import { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\nimport { blob } from \"https://esm.town/v/std/blob/main.ts\";\n\nconst TABLE = \"c4e7_cross_invocation\";\nconst MARK = \"shadow/c4e7_cross_invocation_marker.json\";\nconst sleep = (ms:number) => new Promise(r => setTimeout(r, ms));\n\nexport default async function(req: Request): Promise {\n const u = new URL(req.url);\n const action = u.searchParams.get(\"action\") || \"status\";\n const nonce = u.searchParams.get(\"nonce\") || \"default\";\n\n if (action === \"init\") {\n await sqlite.execute(`DROP TABLE IF EXISTS ${TABLE}`);\n await sqlite.execute(`CREATE TABLE ${TABLE}(id INTEGER PRIMARY KEY, v INTEGER NOT NULL, note TEXT NOT NULL)`);\n await sqlite.execute(`INSERT INTO ${TABLE}(id,v,note) VALUES(1,0,'seed')`);\n await blob.setJSON(MARK, {nonce, phase:\"READY\", at:Date.now()});\n return Response.json({ok:true,action,nonce});\n }\n\n if (action === \"hold\") {\n const holdMs = Math.max(500, Math.min(10000, Number(u.searchParams.get(\"ms\") || 4000)));\n const tx = await (sqlite as any).transaction(\"write\");\n const started = Date.now();\n await tx.execute(`UPDATE ${TABLE} SET v=1,note='hold-uncommitted' WHERE id=1`);\n const firstWriteDone = Date.now();\n await blob.setJSON(MARK, {nonce, phase:\"HOLDING\", started, firstWriteDone});\n await sleep(holdMs);\n await tx.commit();\n const committed = Date.now();\n await blob.setJSON(MARK, {nonce, phase:\"COMMITTED\", started, firstWriteDone, committed});\n return Response.json({ok:true,action,nonce,started,firstWriteDone,committed,hold_ms:committed-firstWriteDone});\n }\n\n if (action === \"probe_direct\") {\n const txStart = Date.now();\n const tx = await (sqlite as any).transaction(\"write\");\n const txObjectAt = Date.now();\n const r = await tx.execute(`SELECT v,note FROM ${TABLE} WHERE id=1`);\n const firstReadAt = Date.now();\n const seenV = Number((r.rows[0] as any).v);\n const seenNote = String((r.rows[0] as any).note);\n await tx.execute({sql:`UPDATE ${TABLE} SET v=?,note='probe-committed' WHERE id=1`,args:[seenV+1]});\n await tx.commit();\n const committedAt = Date.now();\n return Response.json({\n ok:true,action,nonce,\n txStart,txObjectAt,firstReadAt,committedAt,\n tx_object_delay_ms:txObjectAt-txStart,\n first_statement_delay_ms:firstReadAt-txObjectAt,\n seen_v:seenV,seen_note:seenNote\n });\n }\n\n if (action === \"orchestrate\") {\n const holdMs = Math.max(500, Math.min(5000, Number(u.searchParams.get(\"ms\") || 1500)));\n const tx = await (sqlite as any).transaction(\"write\");\n const started = Date.now();\n await tx.execute(`UPDATE ${TABLE} SET v=1,note='orchestrator-uncommitted' WHERE id=1`);\n const firstWriteDone = Date.now();\n\n let probeResolvedAt: number | null = null;\n const self = new URL(req.url);\n self.search = `?action=probe_direct&nonce=${encodeURIComponent(nonce)}`;\n const probePromise = fetch(self).then(async (resp) => {\n const body = await resp.json();\n probeResolvedAt = Date.now();\n return {http_status: resp.status, body};\n });\n\n await sleep(holdMs);\n const preCommit = Date.now();\n const probeResolvedBeforeCommit = probeResolvedAt !== null;\n await tx.commit();\n const committed = Date.now();\n\n let probe:any;\n try {\n probe = await Promise.race([\n probePromise,\n sleep(6000).then(() => ({http_status:599, body:{ok:false,error:\"PROBE_TIMEOUT\"}}))\n ]);\n } catch (e) {\n probe = {http_status:598, body:{ok:false,error:String(e)}};\n }\n\n return Response.json({\n ok:true,action,nonce,started,firstWriteDone,preCommit,committed,hold_ms:preCommit-firstWriteDone,\n probe_resolved_before_commit: probeResolvedBeforeCommit,\n probe_resolved_at: probeResolvedAt,\n probe\n });\n }\n\n if (action === \"final\") {\n const r = await sqlite.execute(`SELECT v,note FROM ${TABLE} WHERE id=1`);\n let m:any = null;\n try { m = JSON.parse(await (await blob.get(MARK)).text()); } catch {}\n return Response.json({ok:true,action,nonce,row:r.rows[0],marker:m});\n }\n\n return Response.json({ok:true,action:\"status\"});\n}\n",[],[317],"ef640817-4b1d-419e-89c5-09793469460b","crash_atomicity_regression_runner_v1.ts","7b655b80-aaaf-11f1-9295-1607ee4eb77e",12,["D",1788780609126],"const BASE=\"https://mosadek--2466ba10a99011f19b5c1607ee4eb77e.web.val.run\";\nasync function call(action:string,qs:Record={}){\n const u=new URL(BASE);u.searchParams.set(\"action\",action);u.searchParams.set(\"nonce\",\"live-chain-incident-20260907\");\n for(const [k,v] of Object.entries(qs))u.searchParams.set(k,String(v));\n const t0=Date.now();const r=await fetch(u);const raw=await r.text();let body:any;try{body=JSON.parse(raw)}catch{body={raw}};\n return {action,status:r.status,ms:Date.now()-t0,body};\n}\nfunction rowv(x:any){return Number(x?.body?.row?.v);}\nexport default async function(){\n const out:any[]=[];\n out.push(await call(\"init\"));\n out.push(await call(\"commit_control\",{v:7}));\n if(rowv(out.at(-1))!==7)throw new Error(\"CONTROL_COMMIT_FAILED\");\n\n for(const tc of [\n {action:\"throw_unhandled\",v:20},\n {action:\"return_open\",v:30},\n {action:\"abandon\",v:40}\n ]){\n out.push(await call(\"reset\",{v:7}));\n out.push(await call(tc.action,{v:tc.v}));\n out.push(await call(\"check\"));\n const afterCheck=rowv(out.at(-1));\n out.push(await call(\"post_write\",{delta:1}));\n const afterPost=rowv(out.at(-1));\n if(afterCheck!==7)throw new Error(tc.action+\"_UNCOMMITTED_ROW_BECAME_DURABLE_\"+afterCheck);\n if(afterPost!==8)throw new Error(tc.action+\"_POST_WRITE_FAILED_\"+afterPost);\n }\n return {ok:true,classification:\"CRASH_ATOMICITY_PARTIAL_REGRESSION_PASS\",cases:[\"throw_unhandled\",\"return_open\",\"abandon\"],out};\n}",[],[325],"5685259f-cab2-4cab-9b32-7d365aa0f390","crash_atomicity_regression_invoke_q9x4.ts","1f6965ae-aacf-11f1-8e19-1607ee4eb77e",["D",1788794299916],"import run from \"./crash_atomicity_regression_runner_v1.ts\";\nimport { blob } from \"https://esm.town/v/std/blob/main.ts\";\nconst result=await run();\nconst receipt={\n schema:\"BRAIN_VAL_NATIVE_TRANSACTION_CRASH_ATOMICITY_FRESH_REPLAY_Q9X4_V1\",\n observed_at:new Date().toISOString(),\n task_id:\"BRAIN-VAL-NATIVE-TRANSACTION-CRASH-ATOMICITY-FALSIFICATION-V1-20260906\",\n disposable_val:\"mosadek/brain-shadow-tx-c4e7\",\n classification:result.classification,\n result\n};\nconst raw=JSON.stringify(receipt,null,2)+\"\\n\";\nconst d=await crypto.subtle.digest(\"SHA-256\",new TextEncoder().encode(raw));\nconst sha256=[...new Uint8Array(d)].map(x=>x.toString(16).padStart(2,\"0\")).join(\"\");\nconst key=\"evidence/q9x4/crash_atomicity_fresh_replay_v1.json\";\nawait blob.set(key,raw);\nconsole.log(JSON.stringify({ok:true,key,sha256,bytes:new TextEncoder().encode(raw).length,classification:result.classification,cases:result.cases}));\nexport default {ok:true,key,sha256,receipt};\n",[],[333],"2e332d9e-5b44-4aa3-b4fd-cac7805955e4","crash_atomicity_probe.ts","2466ba10-a990-11f1-9b5c-1607ee4eb77e",10,["D",1788657197621],"import { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\nimport { blob } from \"https://esm.town/v/std/blob/main.ts\";\n\nconst T=\"c4e7_crash_atomicity\";\nconst MARK=\"shadow/c4e7_crash_atomicity_marker.json\";\nconst sleep=(ms:number)=>new Promise(r=>setTimeout(r,ms));\n\nasync function readRow(){\n const r=await sqlite.execute(`SELECT v,note FROM ${T} WHERE id=1`);\n return r.rows[0]??null;\n}\nasync function setMarker(x:any){await blob.setJSON(MARK,{...x,at:Date.now()});}\n\nexport default async function(req:Request):Promise{\n const u=new URL(req.url);\n const action=u.searchParams.get(\"action\")||\"status\";\n const nonce=u.searchParams.get(\"nonce\")||\"default\";\n\n if(action===\"init\"){\n await sqlite.execute(`DROP TABLE IF EXISTS ${T}`);\n await sqlite.execute(`CREATE TABLE ${T}(id INTEGER PRIMARY KEY,v INTEGER NOT NULL,note TEXT NOT NULL)`);\n await sqlite.execute(`INSERT INTO ${T}(id,v,note) VALUES(1,0,'baseline')`);\n await setMarker({nonce,action,phase:\"READY\"});\n return Response.json({ok:true,action,nonce,row:await readRow()});\n }\n\n if(action===\"reset\"){\n const v=Number(u.searchParams.get(\"v\")||\"0\");\n const tx=await (sqlite as any).transaction(\"write\");\n await tx.execute({sql:`UPDATE ${T} SET v=?,note='baseline' WHERE id=1`,args:[v]});\n await tx.commit();\n await setMarker({nonce,action,phase:\"RESET\",v});\n return Response.json({ok:true,action,nonce,row:await readRow()});\n }\n\n if(action===\"commit_control\"){\n const value=Number(u.searchParams.get(\"v\")||\"10\");\n const tx=await (sqlite as any).transaction(\"write\");\n const started=Date.now();\n await tx.execute({sql:`UPDATE ${T} SET v=?,note='committed-control' WHERE id=1`,args:[value]});\n const wrote=Date.now();\n await tx.commit();\n const committed=Date.now();\n await setMarker({nonce,action,phase:\"COMMITTED\",value,started,wrote,committed});\n return Response.json({ok:true,action,nonce,started,wrote,committed,row:await readRow()});\n }\n\n if(action===\"throw_unhandled\"){\n const value=Number(u.searchParams.get(\"v\")||\"20\");\n const tx=await (sqlite as any).transaction(\"write\");\n const started=Date.now();\n await tx.execute({sql:`UPDATE ${T} SET v=?,note='unhandled-uncommitted' WHERE id=1`,args:[value]});\n const wrote=Date.now();\n await setMarker({nonce,action,phase:\"WROTE_UNCOMMITTED\",value,started,wrote});\n throw new Error(\"C4E7_INTENTIONAL_UNHANDLED_AFTER_WRITE\");\n }\n\n if(action===\"return_open\"){\n const value=Number(u.searchParams.get(\"v\")||\"30\");\n const tx=await (sqlite as any).transaction(\"write\");\n const started=Date.now();\n await tx.execute({sql:`UPDATE ${T} SET v=?,note='return-open-uncommitted' WHERE id=1`,args:[value]});\n const wrote=Date.now();\n await setMarker({nonce,action,phase:\"RETURNING_WITH_TX_OPEN\",value,started,wrote});\n return Response.json({ok:true,action,nonce,returned_with_open_transaction:true,started,wrote});\n }\n\n if(action===\"abandon\"){\n const value=Number(u.searchParams.get(\"v\")||\"40\");\n let tx:any=await (sqlite as any).transaction(\"write\");\n const started=Date.now();\n await tx.execute({sql:`UPDATE ${T} SET v=?,note='abandoned-uncommitted' WHERE id=1`,args:[value]});\n const wrote=Date.now();\n tx=null;\n await setMarker({nonce,action,phase:\"REFERENCE_DROPPED\",value,started,wrote});\n await sleep(250);\n return Response.json({ok:true,action,nonce,reference_dropped:true,started,wrote,returned:Date.now()});\n }\n\n if(action===\"timeout_hold\"){\n const value=Number(u.searchParams.get(\"v\")||\"50\");\n const ms=Math.max(61000,Math.min(90000,Number(u.searchParams.get(\"ms\")||70000)));\n const tx=await (sqlite as any).transaction(\"write\");\n const started=Date.now();\n await tx.execute({sql:`UPDATE ${T} SET v=?,note='timeout-uncommitted' WHERE id=1`,args:[value]});\n const wrote=Date.now();\n await setMarker({nonce,action,phase:\"TIMEOUT_HOLDING\",value,started,wrote,requested_ms:ms});\n await sleep(ms);\n await tx.commit();\n const committed=Date.now();\n await setMarker({nonce,action,phase:\"TIMEOUT_PATH_COMMITTED\",value,started,wrote,committed});\n return Response.json({ok:true,action,nonce,started,wrote,committed,row:await readRow()});\n }\n\n if(action===\"check\"){\n let marker:any=null;try{marker=JSON.parse(await (await blob.get(MARK)).text())}catch{}\n const started=Date.now();\n const row=await readRow();\n return Response.json({ok:true,action,nonce,started,read_at:Date.now(),row,marker});\n }\n\n if(action===\"post_write\"){\n const delta=Number(u.searchParams.get(\"delta\")||\"1\");\n const txStart=Date.now();\n const tx=await (sqlite as any).transaction(\"write\");\n const txObjectAt=Date.now();\n const r=await tx.execute(`SELECT v FROM ${T} WHERE id=1`);\n const firstStatementAt=Date.now();\n const before=Number((r.rows[0] as any).v);\n await tx.execute({sql:`UPDATE ${T} SET v=?,note='post-write' WHERE id=1`,args:[before+delta]});\n await tx.commit();\n const committedAt=Date.now();\n return Response.json({ok:true,action,nonce,before,after:before+delta,txStart,txObjectAt,firstStatementAt,committedAt,first_statement_delay_ms:firstStatementAt-txObjectAt,row:await readRow()});\n }\n\n return Response.json({ok:true,action:\"status\"});\n}",[],[340],"daaaae40-fa92-4bbc-95fb-e4f0600f707d","checkpoint_two_phase_probe_1319.ts","57d51118-aab1-11f1-94a6-1607ee4eb77e",22,["D",1788781408447],"import { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\nimport { blob } from \"https://esm.town/v/std/blob/main.ts\";\n\nconst P=\"p0cp1319_\";\nconst M=P+\"meta\", D=P+\"data\", R=P+\"replicas\";\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 init(){\n for(const t of [R,D,M])await sqlite.execute(`DROP TABLE IF EXISTS ${t}`);\n await sqlite.execute(`CREATE TABLE ${M}(id INTEGER PRIMARY KEY,generation INTEGER NOT NULL,head TEXT NOT NULL)`);\n await sqlite.execute(`CREATE TABLE ${D}(id INTEGER PRIMARY KEY,v TEXT NOT NULL)`);\n await sqlite.execute(`CREATE TABLE ${R}(id INTEGER PRIMARY KEY,generation INTEGER NOT NULL,head TEXT NOT NULL,uri TEXT NOT NULL,snapshot_sha256 TEXT NOT NULL,UNIQUE(generation,head))`);\n await sqlite.execute(`INSERT INTO ${M} VALUES(1,10,'H10')`);\n await sqlite.execute(`INSERT INTO ${D} VALUES(1,'alpha')`);\n}\nasync function capture(){\n const tx:any=await (sqlite as any).transaction(\"read\");\n try{\n const m:any=(await tx.execute(`SELECT generation,head FROM ${M} WHERE id=1`)).rows[0];\n const rows:any[]=(await tx.execute(`SELECT * FROM ${D} ORDER BY id`)).rows as any[];\n const payload={schema:\"P0_CHECKPOINT_PROBE\",generation:Number(m.generation),head:String(m.head),rows};\n const raw=JSON.stringify(payload)+\"\\n\",h=await sha(raw);\n await tx.commit();\n return{generation:Number(m.generation),head:String(m.head),raw,h};\n }catch(e){try{await tx.rollback()}catch{};throw e}\n}\nasync function materialize(c:any,label:string){\n const key=`p0/checkpoint/${label}_g${c.generation}_${c.h.slice(0,16)}.json`;\n await blob.set(key,c.raw);\n const back=await (await blob.get(key)).text();\n if(await sha(back)!==c.h)throw new Error(\"BLOB_READBACK_HASH_MISMATCH\");\n return key;\n}\nasync function register(c:any,key:string){\n const tx:any=await (sqlite as any).transaction(\"write\");\n try{\n const m:any=(await tx.execute(`SELECT generation,head FROM ${M} WHERE id=1`)).rows[0];\n if(Number(m.generation)!==c.generation||String(m.head)!==c.head){\n await tx.rollback();\n return{registered:false,reason:\"STALE_CAPTURE\",current:{generation:Number(m.generation),head:String(m.head)}};\n }\n const id=Number((await tx.execute(`SELECT COALESCE(MAX(id),0)+1 n FROM ${R}`)).rows[0].n);\n await tx.execute({sql:`INSERT INTO ${R}(id,generation,head,uri,snapshot_sha256) VALUES(?,?,?,?,?)`,args:[id,c.generation,c.head,key,c.h]});\n await tx.commit();\n return{registered:true,id};\n }catch(e){try{await tx.rollback()}catch{};throw e}\n}\n\nawait init();\nconst c1=await capture();\nconst k1=await materialize(c1,\"normal\");\nconst reg1=await register(c1,k1);\nconst r1=Number((await sqlite.execute(`SELECT COUNT(*) n FROM ${R}`)).rows[0].n);\n\nawait init();\nconst c2=await capture();\nconst k2=await materialize(c2,\"stale\");\nawait sqlite.execute(`UPDATE ${D} SET v='beta' WHERE id=1`);\nawait sqlite.execute(`UPDATE ${M} SET generation=11,head='H11' WHERE id=1`);\nconst reg2=await register(c2,k2);\nconst r2=Number((await sqlite.execute(`SELECT COUNT(*) n FROM ${R}`)).rows[0].n);\nconst orphanReadable=(await (await blob.get(k2)).text())===c2.raw;\n\nconst pass=reg1.registered===true&&r1===1&®2.registered===false&®2.reason===\"STALE_CAPTURE\"&&r2===0&&orphanReadable;\nconsole.log(JSON.stringify({\n schema:\"BRAIN_CHECKPOINT_TWO_PHASE_CONDITIONAL_REGISTRATION_PROBE_V1\",\n classification:\"NONAUTHORITY_DISPOSABLE_EXECUTABLE_EVIDENCE\",\n production_mutation:false,direct_sprites:false,human_authority_approval:false,\n normal:{capture:{generation:c1.generation,head:c1.head,sha256:c1.h},blob:k1,registration:reg1,replica_rows:r1},\n stale:{capture:{generation:c2.generation,head:c2.head,sha256:c2.h},blob:k2,registration:reg2,replica_rows:r2,orphan_blob_readable:orphanReadable},\n verdict:pass?\"PASS_TWO_PHASE_CHECKPOINT_PROTOCOL\":\"FAIL\",\n pass\n},null,2));",[],[348],"e8fbb9a1-935c-4780-a085-b1db9491b1a4","attempt_atomic_fate_probe_m8q4.ts","debf347e-aab1-11f1-8958-1607ee4eb77e",24,["D",1788781634806],"import { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\n\nconst J=\"m8q4_attempt_jobs_v1\", S=\"m8q4_attempt_state_v1\", R=\"m8q4_attempt_receipts_v1\";\ntype Ctx={job_id:string;owner:string;instance:string;attempt:string};\n\nasync function fresh(){\n const j=(await sqlite.execute(`SELECT * FROM ${J} ORDER BY id`)).rows;\n const s=(await sqlite.execute(`SELECT * FROM ${S} ORDER BY id`)).rows;\n const r=(await sqlite.execute(`SELECT * FROM ${R} ORDER BY attempt_id`)).rows;\n return {jobs:j,state:s,receipts:r};\n}\nasync function reset(){\n await sqlite.execute(`DROP TABLE IF EXISTS ${R}`);\n await sqlite.execute(`DROP TABLE IF EXISTS ${S}`);\n await sqlite.execute(`DROP TABLE IF EXISTS ${J}`);\n await sqlite.execute(`CREATE TABLE ${J}(\n id TEXT PRIMARY KEY,state TEXT NOT NULL,lease_owner TEXT,lease_instance_id TEXT,\n lease_attempt_id TEXT,lease_expires_at TEXT,result_json TEXT,updated_at TEXT NOT NULL)`);\n await sqlite.execute(`CREATE TABLE ${S}(id INTEGER PRIMARY KEY CHECK(id=1),counter INTEGER NOT NULL)`);\n await sqlite.execute(`CREATE TABLE ${R}(\n attempt_id TEXT PRIMARY KEY,job_id TEXT NOT NULL,lease_instance_id TEXT NOT NULL,\n payload_sha256 TEXT NOT NULL,result_json TEXT NOT NULL,committed_at TEXT NOT NULL,\n UNIQUE(job_id,lease_instance_id,attempt_id))`);\n await sqlite.execute(`INSERT INTO ${S}(id,counter) VALUES(1,0)`);\n}\nasync function seed(ctx:Ctx, expires=\"+10 minutes\"){\n await sqlite.execute({sql:`INSERT OR REPLACE INTO ${J}\n (id,state,lease_owner,lease_instance_id,lease_attempt_id,lease_expires_at,result_json,updated_at)\n VALUES(?,'LEASED',?,?,?,datetime('now',?),NULL,datetime('now'))`,\n args:[ctx.job_id,ctx.owner,ctx.instance,ctx.attempt,expires]});\n}\nasync function sha(s:string){\n const d=await crypto.subtle.digest(\"SHA-256\",new TextEncoder().encode(s));\n return [...new Uint8Array(d)].map(x=>x.toString(16).padStart(2,\"0\")).join(\"\");\n}\nasync function mutateBound(ctx:Ctx, fault?:string, throwAfterCommit=false){\n const tx:any=await sqlite.transaction(\"write\");\n try{\n const q:any=await tx.execute({sql:`SELECT * FROM ${J}\n WHERE id=? AND state='LEASED' AND lease_owner=? AND lease_instance_id=? AND lease_attempt_id=?\n AND julianday(lease_expires_at)>julianday('now')`,\n args:[ctx.job_id,ctx.owner,ctx.instance,ctx.attempt]});\n if((q.rows||[]).length!==1)throw new Error(\"ATTEMPT_FENCE_FAILED\");\n\n const up:any=await tx.execute(`UPDATE ${S} SET counter=counter+1 WHERE id=1 RETURNING counter`);\n if(fault===\"after_state\")throw new Error(\"FAULT_AFTER_STATE\");\n const result={ok:true,counter:Number(up.rows[0].counter),attempt:ctx.attempt};\n const resultJson=JSON.stringify(result);\n const payloadHash=await sha(JSON.stringify(ctx));\n\n await tx.execute({sql:`INSERT INTO ${R}\n (attempt_id,job_id,lease_instance_id,payload_sha256,result_json,committed_at)\n VALUES(?,?,?,?,?,datetime('now'))`,\n args:[ctx.attempt,ctx.job_id,ctx.instance,payloadHash,resultJson]});\n if(fault===\"after_receipt\")throw new Error(\"FAULT_AFTER_RECEIPT\");\n\n const done:any=await tx.execute({sql:`UPDATE ${J}\n SET state='COMPLETE',result_json=?,lease_owner=NULL,lease_instance_id=NULL,\n lease_attempt_id=NULL,lease_expires_at=NULL,updated_at=datetime('now')\n WHERE id=? AND state='LEASED' AND lease_owner=? AND lease_instance_id=? AND lease_attempt_id=?\n AND julianday(lease_expires_at)>julianday('now') RETURNING id`,\n args:[resultJson,ctx.job_id,ctx.owner,ctx.instance,ctx.attempt]});\n if((done.rows||[]).length!==1)throw new Error(\"ATTEMPT_PRECOMMIT_FENCE_FAILED\");\n if(fault===\"after_job_complete\")throw new Error(\"FAULT_AFTER_JOB_COMPLETE\");\n await tx.commit();\n if(throwAfterCommit)throw new Error(\"SIMULATED_ACK_LOSS_AFTER_COMMIT\");\n return result;\n }catch(e){\n try{await tx.rollback()}catch{}\n throw e;\n }\n}\n\nfunction assert(x:any,msg:string){if(!x)throw new Error(\"ASSERT:\"+msg)}\n\nexport async function main(){\n const tests:any[]=[];\n const base:Ctx={job_id:\"J\",owner:\"W\",instance:\"I1\",attempt:\"A1\"};\n\n await reset(); await seed(base);\n const ok=await mutateBound(base);\n let a=await fresh();\n assert((a.state[0] as any).counter===1,\"success_state\");\n assert((a.jobs[0] as any).state===\"COMPLETE\",\"success_job_complete\");\n assert(a.receipts.length===1,\"success_receipt\");\n tests.push({id:\"SUCCESS_ATOMIC_FATE\",pass:true});\n\n for(const fault of [\"after_state\",\"after_receipt\",\"after_job_complete\"]){\n await reset(); await seed(base);\n try{await mutateBound(base,fault)}catch{}\n a=await fresh();\n assert((a.state[0] as any).counter===0,fault+\"_state_rollback\");\n assert((a.jobs[0] as any).state===\"LEASED\",fault+\"_job_rollback\");\n assert(a.receipts.length===0,fault+\"_receipt_rollback\");\n tests.push({id:\"ROLLBACK_\"+fault.toUpperCase(),pass:true});\n }\n\n await reset(); await seed({...base,instance:\"I2\",attempt:\"A2\"});\n try{await mutateBound(base)}catch{}\n a=await fresh();\n assert((a.state[0] as any).counter===0,\"stale_attempt_state\");\n assert((a.jobs[0] as any).state===\"LEASED\",\"stale_attempt_job\");\n assert(a.receipts.length===0,\"stale_attempt_receipt\");\n tests.push({id:\"STALE_INSTANCE_ATTEMPT_REJECTED\",pass:true});\n\n await reset(); await seed(base,\"-1 minute\");\n try{await mutateBound(base)}catch{}\n a=await fresh();\n assert((a.state[0] as any).counter===0,\"expired_state\");\n assert((a.jobs[0] as any).state===\"LEASED\",\"expired_job\");\n assert(a.receipts.length===0,\"expired_receipt\");\n tests.push({id:\"EXPIRED_ATTEMPT_REJECTED\",pass:true});\n\n await reset(); await seed(base);\n try{await mutateBound(base,undefined,true)}catch(e){\n assert(String(e).includes(\"SIMULATED_ACK_LOSS_AFTER_COMMIT\"),\"ack_loss_error\");\n }\n a=await fresh();\n assert((a.state[0] as any).counter===1,\"ack_loss_state_committed\");\n assert((a.jobs[0] as any).state===\"COMPLETE\",\"ack_loss_job_complete\");\n assert(a.receipts.length===1,\"ack_loss_receipt\");\n tests.push({id:\"ACK_LOSS_AFTER_COMMIT_IS_RECOVERABLE_COMPLETE\",pass:true});\n\n return {schema:\"ATTEMPT_BOUND_ATOMIC_FATE_PROBE_M8Q4_V1\",passed:tests.filter(x=>x.pass).length,failed:tests.filter(x=>!x.pass).length,tests,final:a};\n}\nif(import.meta.main) console.log(JSON.stringify(await main(),null,2));",[],[356],"aa378d0e-95b6-42a4-8301-bd1c16edb7f0","als_tx_probe.ts","5a606040-aab1-11f1-b32f-1607ee4eb77e",23,["D",1788781412724],"import { sqlite as rawSqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\nimport { AsyncLocalStorage } from \"node:async_hooks\";\nconst als=new AsyncLocalStorage();\nconst sleep=(ms:number)=>new Promise(r=>setTimeout(r,ms));\nasync function nested(expected:any,label:string){\n const before=als.getStore()===expected;\n await sleep(25);\n const after=als.getStore()===expected;\n const db=als.getStore()??rawSqlite;\n const rr:any=await db.execute(\"SELECT 1 AS x\");\n return {label,before,after,query:Number(rr.rows?.[0]?.x)===1};\n}\nexport default async function(){\n const t1:any=await (rawSqlite as any).transaction(\"write\");\n const a=await als.run(t1,async()=>await nested(t1,\"A\"));\n await t1.rollback();\n const [x,y]=await Promise.all([\n (async()=>{const tx:any=await (rawSqlite as any).transaction(\"write\");try{return await als.run(tx,async()=>await nested(tx,\"X\"))}finally{await tx.rollback()}})(),\n (async()=>{const tx:any=await (rawSqlite as any).transaction(\"write\");try{return await als.run(tx,async()=>await nested(tx,\"Y\"))}finally{await tx.rollback()}})()\n ]);\n const ok=[a,x,y].every(z=>z.before&&z.after&&z.query);\n return Response.json({ok,classification:ok?\"ASYNC_LOCAL_TRANSACTION_CONTEXT_PASS\":\"ASYNC_LOCAL_TRANSACTION_CONTEXT_FAIL\",a,x,y});\n}",[],[364],"2e17fbc5-ffc2-4c01-9d36-fc4f5bd416cd","README.md","01a07423-90d5-70c6-8557-59e1c2065c15",["D",1788654882934],"# What's the easiest way to put a form online and save submissions?\n\nRemix this val. It serves a contact form (name, email, message) at `/`, saves every submission to the val's own SQLite database, and lists everything received at `/submissions`. No external services, no API keys, no env vars.\n\n## Setup\n\n1. Remix this val.\n2. Open the HTTP endpoint of `main.tsx` — that is your live form. Share the URL.\n3. Visit `/submissions` on the same URL to see what people sent.\n\nEach remix gets its own private SQLite database, so your submissions stay with your copy.\n\n## Files\n\n- `main.tsx` — Hono routes: GET `/` (form), POST `/submit` (save), GET `/submissions` (list)\n- `db.ts` — creates the `submissions` table and holds the two queries\n- `components/Layout.tsx` — shared page shell with Tailwind (via Twind)\n- `components/FormPage.tsx` — the form\n- `components/SubmissionsPage.tsx` — the list\n\n## Notes\n\n- `/submissions` is public by default. If your form collects anything sensitive, protect that route before sharing the form URL.\n- No client-side JavaScript: the form is a plain HTML POST.\n",[],[372],"5f926b2f-4fde-474f-963c-ec1e70e79b5e","SubmissionsPage.tsx","01a07423-90d5-70c6-8557-50b7c4729ded",["D",1788654882934],"/** @jsxImportSource npm:hono/jsx */\nimport type { Submission } from \"../db.ts\";\nimport Layout from \"./Layout.tsx\";\n\nexport default function SubmissionsPage({ submissions }: { submissions: Submission[] }) {\n return (\n \n

Submissions ({submissions.length})

\n {submissions.length === 0\n ?

Nothing yet. Be the first to submit the form.

\n : (\n

\n
\n {s.name}\n {s.created_at}\n
\n
{s.email}
\n
{s.message}
\n

\n )}\n

\n back to form\n view source\n

\n \n );\n}\n",[],[159,379],"0f48a5fc-bde3-46e3-8c2a-bca3f129e8d6","Layout.tsx","01a07423-90d4-7139-98b5-a88de174e1fd",["D",1788654882934],"/** @jsxImportSource npm:hono/jsx */\n\nexport default function Layout({ title, children }: { title: string; children?: unknown }) {\n return (\n \n \n \n \n {title}\n \n \n \n \n

{children}

\n \n \n );\n}\n",[],[159,386],["D",1788654882934],[],[159,68],"9c3921b0-62ac-4d17-9802-04bfd60ad208",["D",1788654882934],"directory",[171,172,173],[159],["D",1788654882934],["D",1789527031073],{"_11":12,"_128":74},{"_11":12,"_123":124,"_73":74,"_30":72,"_125":126,"_127":24},{"_38":114,"_13":16,"_32":35,"_115":76,"_116":-5,"_117":-5,"_118":-5,"_119":-5,"_120":-5,"_121":14,"_122":12},"ctx",{"_53":-5,"_147":438,"_439":440,"_441":442,"_443":24,"_444":24,"_445":24,"_446":88,"_447":-5,"_448":-7,"_449":-7,"_450":26,"_451":24,"_452":24,"_453":-5,"_454":24,"_455":24,"_456":24,"_457":-5},"ENV",{"_409":410,"_411":412,"_413":16,"_414":415,"_416":417,"_418":419,"_420":421,"_422":423,"_424":425,"_426":427,"_428":429,"_430":431,"_432":433,"_434":435,"_436":437},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","RENDER_GIT_COMMIT","fdb67791413f4386b4dbf18f354029a617f6160f","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 · FormPage.tsx