[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8},"actionData","errors","root",{"_108":109,"_110":111},"routes/embed.x.$handle.$name.$",{"_9":10,"_11":12,"_13":14,"_15":16,"_17":18,"_19":20,"_21":-5},"handle","mosadek","name","r3a4-82c51675-shadow","path","capacity/val_native_mutation_slice_v1_candidate.ts","project",{"_22":48,"_11":12,"_35":49,"_50":-5,"_51":44,"_52":53,"_54":53,"_55":56,"_57":-5,"_58":59,"_60":61,"_62":34,"_63":-5,"_64":-5,"_65":38,"_66":67,"_68":69,"_70":71,"_72":73,"_74":-5,"_75":76,"_77":76,"_78":79,"_80":79,"_81":79,"_82":76,"_83":76,"_84":85,"_86":87,"_88":89,"_90":44},"file",{"_22":23,"_11":24,"_25":26,"_27":28,"_29":30,"_31":32,"_33":34,"_35":36,"_37":38,"_39":40,"_41":42,"_43":44,"_45":-5,"_13":46},"permalink","https://www.val.town/x/mosadek/r3a4-82c51675-shadow/code/capacity/val_native_mutation_slice_v1_candidate.ts","extension","id","876542a3-9d1e-4188-a669-9d88713922f5","val_native_mutation_slice_v1_candidate.ts","fileId","01a09317-8b37-763e-aa0d-72b389f022cb","parentId","01a09317-8b37-763e-aa0d-84a4183a01ec","branchId","667edb8b-aaf6-4374-bf1c-2397f495e068","branchVersion",1,"latest",true,"createdAt",["D",1789174188714],"version",0,"fileType","script","content","import { blob } from \"https://esm.town/v/std/blob/main.ts\";\nimport { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\n\nconst SNAP=\"snapshots/brain_snapshot_g1502_81b7279d60860f9e.json\";\nconst EXPECT_BRAIN_SHA=\"8f463c630e7c3836c767ec0feea7d40bd774a10bb5f60a193bc5bbd4d9b1ed9c\";\nconst EXPECT_SNAPSHOT_SHA=\"81b7279d60860f9eac3aacaf9cc3fdb9c1c85c8545b725104ebfe3ce5899af87\";\nconst P=\"svm1_\";\nconst enc=new TextEncoder();\n\nasync function sha256Bytes(b:Uint8Array){\n const d=await crypto.subtle.digest(\"SHA-256\",b);\n return [...new Uint8Array(d)].map(x=>x.toString(16).padStart(2,\"0\")).join(\"\");\n}\nasync function sha256Text(s:string){return sha256Bytes(enc.encode(s));}\n\ntype PJ =\n | {t:\"null\"}\n | {t:\"bool\",v:boolean}\n | {t:\"str\",v:string}\n | {t:\"int\",v:bigint}\n | {t:\"float\",v:number}\n | {t:\"arr\",v:PJ[]}\n | {t:\"obj\",v:Map};\n\nfunction expFmt(e:number){return \"e\"+(e>=0?\"+\":\"-\")+Math.abs(e).toString().padStart(2,\"0\");}\nfunction fixedToSci(s:string){\n let sign=\"\"; if(s.startsWith(\"-\")){sign=\"-\";s=s.slice(1);}\n let exp:number,digits:string;\n if(s.includes(\".\")){\n const [ip,fp]=s.split(\".\");\n if(ip!==\"0\"){exp=ip.length-1;digits=(ip+fp).replace(/0+$/,\"\");}\n else {const i=[...fp].findIndex(c=>c!==\"0\");if(i<0)return sign+\"0.0\";exp=-(i+1);digits=fp.slice(i).replace(/0+$/,\"\");}\n } else {exp=s.length-1;digits=s.replace(/0+$/,\"\");}\n const mant=digits.length===1?digits:digits[0]+\".\"+digits.slice(1);\n return sign+mant+expFmt(exp);\n}\nfunction pyFloatRepr(v:number){\n if(Number.isNaN(v))return \"NaN\";\n if(v===Infinity)return \"Infinity\";\n if(v===-Infinity)return \"-Infinity\";\n if(Object.is(v,-0))return \"-0.0\";\n const a=Math.abs(v), s=v.toString();\n if(s.includes(\"e\")){const [m,e]=s.split(\"e\");return m+expFmt(Number(e));}\n if(a!==0&&(a<1e-4||a>=1e16))return fixedToSci(s);\n if(Number.isInteger(v))return s+\".0\";\n return s;\n}\nfunction cmpPyString(a:string,b:string){\n const aa=[...a],bb=[...b],n=Math.min(aa.length,bb.length);\n for(let i=0;i{while(i{throw new Error(\"PYJSON_PARSE:\"+m+\"@\"+i);};\n const str=():string=>{\n const start=i;if(src[i]!=='\"')err(\"expected string\");i++;\n let esc=false;\n while(i{\n ws();\n if(src.startsWith(\"null\",i)){i+=4;return{t:\"null\"};}\n if(src.startsWith(\"true\",i)){i+=4;return{t:\"bool\",v:true};}\n if(src.startsWith(\"false\",i)){i+=5;return{t:\"bool\",v:false};}\n if(src.startsWith(\"NaN\",i)){i+=3;return{t:\"float\",v:NaN};}\n if(src.startsWith(\"Infinity\",i)){i+=8;return{t:\"float\",v:Infinity};}\n if(src.startsWith(\"-Infinity\",i)){i+=9;return{t:\"float\",v:-Infinity};}\n if(src[i]==='\"')return{t:\"str\",v:str()};\n if(src[i]===\"[\"){\n i++;const a:PJ[]=[];ws();if(src[i]===\"]\"){i++;return{t:\"arr\",v:a};}\n while(true){a.push(val());ws();if(src[i]===\",\"){i++;continue;}if(src[i]===\"]\"){i++;break;}err(\"array sep\");}\n return{t:\"arr\",v:a};\n }\n if(src[i]===\"{\"){\n i++;const o=new Map();ws();if(src[i]===\"}\"){i++;return{t:\"obj\",v:o};}\n while(true){ws();const k=str();ws();if(src[i]!==\":\")err(\"object colon\");i++;o.set(k,val());ws();if(src[i]===\",\"){i++;continue;}if(src[i]===\"}\"){i++;break;}err(\"object sep\");}\n return{t:\"obj\",v:o};\n }\n const m=src.slice(i).match(/^-?(?:0|[1-9]\\d*)(?:\\.\\d+)?(?:[eE][+-]?\\d+)?/);\n if(!m)err(\"value\");\n const tok=m[0];i+=tok.length;\n if(/[.eE]/.test(tok))return{t:\"float\",v:Number(tok)};\n return{t:\"int\",v:BigInt(tok)};\n };\n const out=val();ws();if(i!==src.length)err(\"trailing\");return out;\n}\nfunction dumpPythonJson(x:PJ):string{\n switch(x.t){\n case\"null\":return\"null\";\n case\"bool\":return x.v?\"true\":\"false\";\n case\"str\":return pyString(x.v);\n case\"int\":return x.v.toString();\n case\"float\":return pyFloatRepr(x.v);\n case\"arr\":return\"[\"+x.v.map(dumpPythonJson).join(\",\")+\"]\";\n case\"obj\":return\"{\"+[...x.v.entries()].sort((a,b)=>cmpPyString(a[0],b[0])).map(([k,v])=>pyString(k)+\":\"+dumpPythonJson(v)).join(\",\")+\"}\";\n }\n}\nfunction q(v:any){return JSON.stringify(v);}\nfunction eventBody(e:any,payload:string){\n return \"{\"+\n q(\"agent_id\")+\":\"+q(e.agent_id)+\",\"+\n q(\"event_uuid\")+\":\"+q(e.event_uuid)+\",\"+\n q(\"payload\")+\":\"+payload+\",\"+\n q(\"prev_hash\")+\":\"+q(e.prev_hash)+\",\"+\n q(\"task_id\")+\":\"+q(e.task_id)+\",\"+\n q(\"ts\")+\":\"+q(e.ts)+\",\"+\n q(\"type\")+\":\"+q(e.type)+\",\"+\n q(\"workstream\")+\":\"+q(e.workstream)+\"}\";\n}\nasync function verifyEvents(events:any[]){\n let prev=\"0\".repeat(64),badPrev=0,badHash=0,badPayload=0;\n const examples:any[]=[];\n for(const e of events){\n let payload:string;\n try{payload=dumpPythonJson(parsePythonJson(e.payload_json));}\n catch(ex){badPayload++;payload=e.payload_json;if(examples.length<8)examples.push({id:e.id,kind:\"PYJSON_PARSE\",error:String(ex)});}\n if(payload!==e.payload_json){badPayload++;if(examples.length<8)examples.push({id:e.id,kind:\"PAYLOAD\",stored:e.payload_json,computed:payload});}\n const h=await sha256Text(eventBody(e,payload));\n if(e.prev_hash!==prev){badPrev++;if(examples.length<8)examples.push({id:e.id,kind:\"PREV\"});}\n if(h!==e.event_hash){badHash++;if(examples.length<8)examples.push({id:e.id,kind:\"HASH\",stored:e.event_hash,computed:h});}\n prev=e.event_hash;\n }\n return{bad_prev:badPrev,bad_hash:badHash,bad_payload:badPayload,computed_head:prev,examples,pass:badPrev===0&&badHash===0&&badPayload===0};\n}\nconst TABLES=[\"task_invariant_history\",\"task_context_history\",\"claim_deps\",\"claims\",\"replicas\",\"artifacts\",\"events\",\"tasks\",\"agents\",\"workstreams\",\"meta\"];\nconst schemaSql=[\n`CREATE TABLE ${P}meta(key TEXT PRIMARY KEY,value TEXT NOT NULL)`,\n`CREATE TABLE ${P}workstreams(id TEXT PRIMARY KEY,mission TEXT NOT NULL,head_generation INTEGER NOT NULL DEFAULT 0,verified_state TEXT NOT NULL DEFAULT '{}',updated_at TEXT NOT NULL)`,\n`CREATE TABLE ${P}agents(id TEXT PRIMARY KEY,parent_id TEXT,type TEXT NOT NULL,workstream TEXT NOT NULL,role TEXT NOT NULL,status TEXT NOT NULL,boot_generation INTEGER NOT NULL,last_generation INTEGER NOT NULL,last_seen TEXT NOT NULL,capabilities_json TEXT NOT NULL DEFAULT '[]')`,\n`CREATE TABLE ${P}tasks(id TEXT PRIMARY KEY,workstream TEXT NOT NULL,state TEXT NOT NULL,priority REAL NOT NULL DEFAULT 0,depends_json TEXT NOT NULL DEFAULT '[]',success_condition TEXT NOT NULL,decision_value TEXT NOT NULL,context_manifest TEXT NOT NULL DEFAULT '{}',lease_owner TEXT,lease_mode TEXT,lease_generation INTEGER,lease_expires_at TEXT,created_at TEXT NOT NULL,updated_at TEXT NOT NULL,result_event_id INTEGER,requires_json TEXT NOT NULL DEFAULT '[]',dedupe_key TEXT,assigned_agent TEXT,delegated_by TEXT,writes_json TEXT NOT NULL DEFAULT '[]',guards_json TEXT NOT NULL DEFAULT '[]')`,\n`CREATE TABLE ${P}events(id INTEGER PRIMARY KEY,event_uuid TEXT UNIQUE 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 UNIQUE NOT NULL)`,\n`CREATE TABLE ${P}artifacts(sha256 TEXT PRIMARY KEY,size INTEGER NOT NULL,logical_name TEXT,producer_agent TEXT,task_id TEXT,storage_json TEXT NOT NULL DEFAULT '[]',created_at TEXT NOT NULL)`,\n`CREATE TABLE ${P}replicas(id INTEGER PRIMARY KEY,generation INTEGER NOT NULL,provider TEXT NOT NULL,uri TEXT NOT NULL,snapshot_sha256 TEXT NOT NULL,event_head_hash TEXT NOT NULL,verified INTEGER NOT NULL DEFAULT 0,created_at TEXT NOT NULL,UNIQUE(generation,provider,uri))`,\n`CREATE TABLE ${P}claims(id TEXT PRIMARY KEY,workstream TEXT NOT NULL,status TEXT NOT NULL,statement_json TEXT NOT NULL,statement_sha256 TEXT NOT NULL,evidence_json TEXT NOT NULL DEFAULT '[]',created_generation INTEGER NOT NULL,invalidated_by TEXT,created_at TEXT NOT NULL,updated_at TEXT NOT NULL)`,\n`CREATE TABLE ${P}claim_deps(parent_claim TEXT NOT NULL,child_claim TEXT NOT NULL,PRIMARY KEY(parent_claim,child_claim))`,\n`CREATE TABLE ${P}task_context_history(id INTEGER PRIMARY KEY,task_id TEXT NOT NULL,version INTEGER NOT NULL,old_context_json TEXT NOT NULL,new_context_json TEXT NOT NULL,reason TEXT NOT NULL,evidence_json TEXT NOT NULL DEFAULT '[]',agent_id TEXT,event_id INTEGER NOT NULL,created_at TEXT NOT NULL,UNIQUE(task_id,version))`,\n`CREATE TABLE ${P}task_invariant_history(id INTEGER PRIMARY KEY,task_id TEXT NOT NULL,version INTEGER NOT NULL,old_dedupe_key TEXT,new_dedupe_key TEXT NOT NULL,old_writes_json TEXT NOT NULL,new_writes_json TEXT NOT NULL,old_guards_json TEXT NOT NULL DEFAULT '[]',new_guards_json TEXT NOT NULL DEFAULT '[]',reason TEXT NOT NULL,evidence_json TEXT NOT NULL DEFAULT '[]',agent_id TEXT,event_id INTEGER NOT NULL,created_at TEXT NOT NULL,UNIQUE(task_id,version))`\n];\nasync function insertRows(tx:any,table:string,cols:string[],rows:any[],chunk=20){\n for(let i=0;i\"?\").join(\",\")+\")\";\n const sql=`INSERT INTO ${P}${table}(${cols.join(\",\")}) VALUES ${part.map(()=>tuple).join(\",\")}`;\n const args=part.flatMap(r=>cols.map(c=>r[c]===undefined?null:r[c]));\n await tx.execute({sql,args});\n }\n}\nconst raw=await (await blob.get(SNAP)).text();\nconst rawSha=await sha256Text(raw);\nconst d:any=JSON.parse(raw),s=d.snapshot||{},events=d.events||[];\nconst brain=(d.recovery_files||[]).find((x:any)=>x.logical_path===\"brain.py\");\nif(!brain||brain.sha256!==EXPECT_BRAIN_SHA)throw new Error(\"SOURCE_BRAIN_SHA_MISMATCH\");\nconst recovery:any[]=[];\nfor(const f of d.recovery_files||[]){\n const b=enc.encode(String(f.content_utf8||\"\"));\n recovery.push({path:f.logical_path,size_match:b.length===f.size,sha_match:(await sha256Bytes(b))===f.sha256});\n}\nconst sourceVerify=await verifyEvents(events);\nif(!sourceVerify.pass||sourceVerify.computed_head!==s.event_head_hash)throw new Error(\"SOURCE_CHAIN_FAIL\");\nif(rawSha!==EXPECT_SNAPSHOT_SHA)throw new Error(\"SNAPSHOT_SHA_EXACT_FAIL\");\n\nconst pyFixtures:[string,string][]=[\n [\"0\",\"0\"],[\"-0\",\"0\"],[\"0.0\",\"0.0\"],[\"-0.0\",\"-0.0\"],[\"1e-7\",\"1e-07\"],[\"1e16\",\"1e+16\"],\n [\"9007199254740993\",\"9007199254740993\"],[\"-9007199254740993123456789\",\"-9007199254740993123456789\"],\n [\"1.2300\",\"1.23\"],[\"NaN\",\"NaN\"],[\"Infinity\",\"Infinity\"],[\"-Infinity\",\"-Infinity\"],\n [\"{\\\"z\\\":1,\\\"a\\\":2.0}\",\"{\\\"a\\\":2.0,\\\"z\\\":1}\"],[\"[9007199254740993,-0.0,1e-7]\",\"[9007199254740993,-0.0,1e-07]\"]\n];\nconst pyFixtureFailures=pyFixtures.map(([input,want])=>({input,want,got:dumpPythonJson(parsePythonJson(input))})).filter(x=>x.want!==x.got);\nif(pyFixtureFailures.length)throw new Error(\"PYJSON_FIXTURE_FAIL\");\n\nconst tx=await (sqlite as any).transaction(\"write\");\ntry{\n for(const t of TABLES)await tx.execute(`DROP TABLE IF EXISTS ${P}${t}`);\n for(const q of schemaSql)await tx.execute(q);\n await tx.execute(`CREATE UNIQUE INDEX ${P}ux_tasks_open_dedupe ON ${P}tasks(workstream,dedupe_key) WHERE dedupe_key IS NOT NULL AND state IN ('READY','LEASED')`);\n await insertRows(tx,\"meta\",[\"key\",\"value\"],[\n {key:\"generation\",value:String(s.generation)},\n {key:\"event_head_hash\",value:String(s.event_head_hash)},\n {key:\"kernel_version\",value:\"brain-kernel-v1.18\"},\n {key:\"schema_version\",value:\"9\"}\n ]);\n await insertRows(tx,\"workstreams\",[\"id\",\"mission\",\"head_generation\",\"verified_state\",\"updated_at\"],s.workstreams||[]);\n await insertRows(tx,\"agents\",[\"id\",\"parent_id\",\"type\",\"workstream\",\"role\",\"status\",\"boot_generation\",\"last_generation\",\"last_seen\",\"capabilities_json\"],s.agents||[]);\n for(const t of s.tasks||[])if(!Number.isFinite(Number(t.priority)))throw new Error(\"NONFINITE_PRIORITY:\"+t.id);\n await insertRows(tx,\"tasks\",[\"id\",\"workstream\",\"state\",\"priority\",\"depends_json\",\"success_condition\",\"decision_value\",\"context_manifest\",\"lease_owner\",\"lease_mode\",\"lease_generation\",\"lease_expires_at\",\"created_at\",\"updated_at\",\"result_event_id\",\"requires_json\",\"dedupe_key\",\"assigned_agent\",\"delegated_by\",\"writes_json\",\"guards_json\"],s.tasks||[],10);\n await insertRows(tx,\"events\",[\"id\",\"event_uuid\",\"ts\",\"workstream\",\"agent_id\",\"task_id\",\"type\",\"payload_json\",\"prev_hash\",\"event_hash\"],events,10);\n await insertRows(tx,\"artifacts\",[\"sha256\",\"size\",\"logical_name\",\"producer_agent\",\"task_id\",\"storage_json\",\"created_at\"],s.artifacts||d.artifacts||[]);\n await insertRows(tx,\"replicas\",[\"id\",\"generation\",\"provider\",\"uri\",\"snapshot_sha256\",\"event_head_hash\",\"verified\",\"created_at\"],s.replicas||d.replicas||[]);\n await insertRows(tx,\"claims\",[\"id\",\"workstream\",\"status\",\"statement_json\",\"statement_sha256\",\"evidence_json\",\"created_generation\",\"invalidated_by\",\"created_at\",\"updated_at\"],s.claims||[]);\n await insertRows(tx,\"claim_deps\",[\"parent_claim\",\"child_claim\"],s.claim_deps||[]);\n await insertRows(tx,\"task_context_history\",[\"id\",\"task_id\",\"version\",\"old_context_json\",\"new_context_json\",\"reason\",\"evidence_json\",\"agent_id\",\"event_id\",\"created_at\"],s.task_context_history||[]);\n await insertRows(tx,\"task_invariant_history\",[\"id\",\"task_id\",\"version\",\"old_dedupe_key\",\"new_dedupe_key\",\"old_writes_json\",\"new_writes_json\",\"old_guards_json\",\"new_guards_json\",\"reason\",\"evidence_json\",\"agent_id\",\"event_id\",\"created_at\"],s.task_invariant_history||[]);\n await tx.commit();\n}catch(e){try{await tx.rollback()}catch{};throw e;}\n\nconst count=async(t:string)=>Number((await sqlite.execute(`SELECT COUNT(*) n FROM ${P}${t}`)).rows[0].n);\nconst importedEvents=(await sqlite.execute(`SELECT id,event_uuid,ts,workstream,agent_id,task_id,type,payload_json,prev_hash,event_hash FROM ${P}events ORDER BY id`)).rows as any[];\nconst importedVerify=await verifyEvents(importedEvents);\nconst status={\n generation:Number((await sqlite.execute(`SELECT value FROM ${P}meta WHERE key='generation'`)).rows[0].value),\n event_head_hash:String((await sqlite.execute(`SELECT value FROM ${P}meta WHERE key='event_head_hash'`)).rows[0].value),\n kernel_version:String((await sqlite.execute(`SELECT value FROM ${P}meta WHERE key='kernel_version'`)).rows[0].value),\n schema_version:Number((await sqlite.execute(`SELECT value FROM ${P}meta WHERE key='schema_version'`)).rows[0].value),\n workstreams:await count(\"workstreams\"),agents:await count(\"agents\"),tasks:await count(\"tasks\"),events:await count(\"events\"),claims:await count(\"claims\"),\n task_context_history:await count(\"task_context_history\"),task_invariant_history:await count(\"task_invariant_history\")\n};\nawait sqlite.execute(`DROP TABLE IF EXISTS ${P}events_corrupt`);\nawait sqlite.execute(`CREATE TABLE ${P}events_corrupt AS SELECT * FROM ${P}events`);\nconst mid=Math.floor(events.length/2);\nawait sqlite.execute({sql:`UPDATE ${P}events_corrupt SET payload_json=? WHERE id=?`,args:[\"{\\\"directed_corruption\\\":true}\",events[mid].id]});\nconst corrupted=(await sqlite.execute(`SELECT id,event_uuid,ts,workstream,agent_id,task_id,type,payload_json,prev_hash,event_hash FROM ${P}events_corrupt ORDER BY id`)).rows as any[];\nconst corruptionVerify=await verifyEvents(corrupted);\nawait sqlite.execute(`DROP TABLE ${P}events_corrupt`);\n\nconst sourceCounts={workstreams:(s.workstreams||[]).length,agents:(s.agents||[]).length,tasks:(s.tasks||[]).length,events:events.length,claims:(s.claims||[]).length,task_context_history:(s.task_context_history||[]).length,task_invariant_history:(s.task_invariant_history||[]).length};\nconst countMatch=Object.entries(sourceCounts).every(([k,v])=>(status as any)[k]===v);\nconst pass=rawSha===EXPECT_SNAPSHOT_SHA&&recovery.every(x=>x.size_match&&x.sha_match)&&sourceVerify.pass&&importedVerify.pass&&importedVerify.computed_head===s.event_head_hash&&countMatch&&status.generation===s.generation&&status.event_head_hash===s.event_head_hash&&pyFixtureFailures.length===0&&!corruptionVerify.pass;\nconsole.log(JSON.stringify({\n schema:\"BRAIN_VAL_NATIVE_FOUNDATION_V1B_M1\",\n classification:\"NONAUTHORITY_FOUNDATION_CANDIDATE\",\n source:{snapshot:SNAP,raw_sha256:rawSha,brain_py_sha256:brain.sha256,generation:s.generation,event_count:events.length,event_head_hash:s.event_head_hash},\n python_json:{targeted_fixture_count:pyFixtures.length,targeted_failures:pyFixtureFailures.length,all_event_payload_roundtrip_mismatches:sourceVerify.bad_payload},\n recovery,\n source_chain:sourceVerify,\n imported_status:status,source_counts:sourceCounts,count_match:countMatch,\n imported_chain:importedVerify,\n directed_corruption_detected:!corruptionVerify.pass,\n directed_corruption_probe:{bad_prev:corruptionVerify.bad_prev,bad_hash:corruptionVerify.bad_hash,bad_payload:corruptionVerify.bad_payload,examples:corruptionVerify.examples.slice(0,3)},\n namespace:P,no_semantic_command_handlers_enabled:true,canonical_brain_mutation:false,bridge_table_mutation:false,production_routing:false,human_authority_approval:false,direct_sprites:false,\n pass\n},null,2));\n\n// ---- isolated mutation-slice proof; never production-routed ----\nfunction canonJs(x:any):string{\n if(x===null)return\"null\";\n if(typeof x===\"string\")return JSON.stringify(x);\n if(typeof x===\"boolean\")return x?\"true\":\"false\";\n if(typeof x===\"number\")return Number.isInteger(x)?String(x):pyFloatRepr(x);\n if(Array.isArray(x))return\"[\"+x.map(canonJs).join(\",\")+\"]\";\n return\"{\"+Object.keys(x).sort(cmpPyString).map(k=>JSON.stringify(k)+\":\"+canonJs(x[k])).join(\",\")+\"}\";\n}\nfunction isoNow(){return new Date().toISOString().replace(\"Z\",\"+00:00\")}\nfunction expired(s:any){const t=Date.parse(String(s||\"\"));return Number.isFinite(t)&&t(JSON.parse(String(row.writes_json||\"[]\")));if(!w.size)return null;const q:any=await c.execute(`SELECT id,workstream,lease_owner,writes_json FROM ${P}tasks WHERE state='LEASED'`);for(const o of q.rows||[]){const ow=new Set(JSON.parse(String(o.writes_json||\"[]\")));const overlap=[...w].filter(x=>ow.has(x)).sort();if(overlap.length)return{task_id:o.id,resources:overlap}}return null}\nasync function bestReadyM(c:any,ws:string,caps:string[],aid:string){const q:any=await c.execute({sql:`SELECT * FROM ${P}tasks WHERE workstream=? AND state='READY' ORDER BY priority DESC,id`,args:[ws]});const cs=new Set(caps);for(const r of q.rows||[]){if(!r.dedupe_key)continue;if(r.assigned_agent&&r.assigned_agent!==aid)continue;let ctx:any={};try{ctx=JSON.parse(String(r.context_manifest||\"{}\"))}catch{return null}if(ctx.execution_allowed===false)continue;const req:string[]=JSON.parse(String(r.requires_json||\"[]\"));if(req.includes(\"human_authority_approval\"))continue;if(!req.every(x=>cs.has(x)))continue;if(!await depsSat(c,r)||!await guardsSat(c,r))continue;if(await writeConflictM(c,r))continue;return r}return null}\nasync function registerM(aid:string,ws:string,role:string,typ:string,caps:string[]){const tx=await(sqlite as any).transaction(\"write\");try{const w:any=await tx.execute({sql:`SELECT 1 ok FROM ${P}workstreams WHERE id=?`,args:[ws]});if(!w.rows?.[0])throw new Error(\"UNKNOWN_WORKSTREAM\");const ex:any=await tx.execute({sql:`SELECT * FROM ${P}agents WHERE id=?`,args:[aid]});if(ex.rows?.[0])throw new Error(\"TEST_AGENT_ALREADY_EXISTS\");const g=await genM(tx),t=isoNow(),sc=[...new Set(caps)].sort();await tx.execute({sql:`INSERT INTO ${P}agents(id,parent_id,type,workstream,role,status,boot_generation,last_generation,last_seen,capabilities_json) VALUES(?,?,?,?,?,'READY',?,?,?,?)`,args:[aid,null,typ,ws,role,g,g,t,canonJs(sc)]});await eventM(tx,ws,aid,null,\"AGENT_REGISTERED\",{type:typ,role,parent:null,boot_generation:g,capabilities:sc});const ng=await bumpM(tx);await tx.execute({sql:`UPDATE ${P}agents SET last_generation=? WHERE id=?`,args:[ng,aid]});await tx.commit();return{generation:ng}}catch(e){await tx.rollback();throw e}}\nasync function claimM(aid:string,mode=\"INTERACTIVE\",leaseSeconds=1800){const tx=await(sqlite as any).transaction(\"write\");try{const a:any=await tx.execute({sql:`SELECT * FROM ${P}agents WHERE id=?`,args:[aid]});const ag=a.rows?.[0];if(!ag)throw new Error(\"UNKNOWN_AGENT\");const held:any=await tx.execute({sql:`SELECT id,lease_expires_at FROM ${P}tasks WHERE state='LEASED' AND lease_owner=? ORDER BY updated_at DESC LIMIT 1`,args:[aid]});if(held.rows?.[0]){await tx.rollback();return{ok:false,reason:expired(held.rows[0].lease_expires_at)?\"AGENT_HAS_EXPIRED_LEASE_RECOVER_REQUIRED\":\"AGENT_ALREADY_LEASED\"}}const row=await bestReadyM(tx,String(ag.workstream),JSON.parse(String(ag.capabilities_json||\"[]\")),aid);const g=await genM(tx);if(!row){await tx.rollback();return{ok:false,reason:\"NO_READY_TASK\",generation:g}}if(leaseSeconds<60||leaseSeconds>7200)throw new Error(\"LEASE_SECONDS_OUT_OF_RANGE\");const exp=new Date(Date.now()+leaseSeconds*1000).toISOString().replace(\"Z\",\"+00:00\"),t=isoNow();const u:any=await tx.execute({sql:`UPDATE ${P}tasks SET state='LEASED',lease_owner=?,lease_mode=?,lease_generation=?,lease_expires_at=?,updated_at=? WHERE id=? AND state='READY' RETURNING id`,args:[aid,mode,g,exp,t,row.id]});if(!u.rows?.[0])throw new Error(\"CLAIM_RACE_LOST\");await eventM(tx,row.workstream,aid,row.id,\"TASK_LEASED\",{lease_mode:mode,lease_generation:g,lease_expires_at:exp});const ng=await bumpM(tx);await tx.execute({sql:`UPDATE ${P}agents SET status='WORKING',last_generation=?,last_seen=? WHERE id=?`,args:[ng,t,aid]});await tx.execute({sql:`UPDATE ${P}workstreams SET head_generation=?,updated_at=? WHERE id=?`,args:[ng,t,row.workstream]});await tx.commit();return{ok:true,task_id:row.id,lease_generation:g,workstream_generation:ng,lease_expires_at:exp,writes_json:row.writes_json,workstream:row.workstream}}catch(e){await tx.rollback();throw e}}\nasync function commitM(aid:string,taskId:string,expectedWsGen:number,expectedLeaseGen:number,payload:any){const tx=await(sqlite as any).transaction(\"write\");try{const tr:any=await tx.execute({sql:`SELECT * FROM ${P}tasks WHERE id=?`,args:[taskId]});const task=tr.rows?.[0];const ar:any=await tx.execute({sql:`SELECT * FROM ${P}agents WHERE id=?`,args:[aid]});const ag=ar.rows?.[0];if(!task||!ag)throw new Error(\"UNKNOWN_TASK_OR_AGENT\");if(task.workstream!==ag.workstream){await tx.rollback();return{ok:false,reason:\"CROSS_WORKSTREAM_COMMIT_FORBIDDEN\"}}if(task.lease_owner!==aid){await tx.rollback();return{ok:false,reason:\"NOT_LEASE_OWNER\"}}if(Number(task.lease_generation)!==expectedLeaseGen){await tx.rollback();return{ok:false,reason:\"STALE_LEASE_GENERATION\",actual:Number(task.lease_generation),expected:expectedLeaseGen}}if(expired(task.lease_expires_at)){await tx.rollback();return{ok:false,reason:\"LEASE_EXPIRED\"}}const wr:any=await tx.execute({sql:`SELECT head_generation FROM ${P}workstreams WHERE id=?`,args:[task.workstream]});const actual=Number(wr.rows[0].head_generation);if(actual!==expectedWsGen){await tx.rollback();return{ok:false,reason:\"STALE_WORKSTREAM_WRITE\",actual,expected:expectedWsGen}}const ev=await eventM(tx,task.workstream,aid,taskId,\"TASK_RESULT_COMMITTED\",payload);const t=isoNow();const u:any=await tx.execute({sql:`UPDATE ${P}tasks SET state='COMPLETE',result_event_id=?,updated_at=?,lease_owner=NULL,lease_mode=NULL,lease_generation=NULL,lease_expires_at=NULL WHERE id=? AND state='LEASED' AND lease_owner=? RETURNING id`,args:[ev.id,t,taskId,aid]});if(!u.rows?.[0])throw new Error(\"COMMIT_TASK_UPDATE_RACE\");const ng=await bumpM(tx);await tx.execute({sql:`UPDATE ${P}agents SET status='READY',last_generation=?,last_seen=? WHERE id=?`,args:[ng,t,aid]});await tx.execute({sql:`UPDATE ${P}workstreams SET head_generation=?,updated_at=? WHERE id=?`,args:[ng,t,task.workstream]});await tx.commit();return{ok:true,generation:ng,event_id:ev.id}}catch(e){await tx.rollback();throw e}}\nasync function recoverM(){const tx=await(sqlite as any).transaction(\"write\");try{const q:any=await tx.execute(`SELECT * FROM ${P}tasks WHERE state='LEASED' AND lease_expires_at IS NOT NULL`);const rs=(q.rows||[]).filter((r:any)=>expired(r.lease_expires_at));const rec:string[]=[];for(const r of rs){const old=r.lease_owner,t=isoNow();await tx.execute({sql:`UPDATE ${P}tasks SET state='READY',lease_owner=NULL,lease_mode=NULL,lease_generation=NULL,lease_expires_at=NULL,updated_at=? WHERE id=?`,args:[t,r.id]});await eventM(tx,r.workstream,null,r.id,\"TASK_LEASE_RECOVERED\",{previous_owner:old});rec.push(String(r.id))}let g=await genM(tx);if(rec.length){g=await bumpM(tx);for(const ws of [...new Set(rs.map((r:any)=>String(r.workstream)))])await tx.execute({sql:`UPDATE ${P}workstreams SET head_generation=?,updated_at=? WHERE id=?`,args:[g,isoNow(),ws]})}await tx.commit();return{recovered:rec,generation:g}}catch(e){await tx.rollback();throw e}}\n\nconst mutTests:any[]=[];const aid=\"sat-shadow-mut-v1\";const caps=[\"file_analysis\",\"val_town_blob\",\"val_town_write\",\"web_research\"];\nconst reg=await registerM(aid,\"global\",\"shadow-mutation-tester\",\"PROCESS\",caps);mutTests.push({name:\"register\",pass:reg.generation>s.generation,detail:reg});\nconst c1:any=await claimM(aid,\"PROCESS\",900);mutTests.push({name:\"claim\",pass:!!c1.ok,detail:c1});\nif(!c1.ok)throw new Error(\"NO_CLAIMABLE_FIXTURE_TASK\");\nconst gBeforeWrong=Number(await metaGet(sqlite,\"generation\")),hBeforeWrong=await headM(sqlite);const wrong=await commitM(aid,c1.task_id,c1.workstream_generation,c1.lease_generation+999,{probe:\"wrong-lease\"});const gAfterWrong=Number(await metaGet(sqlite,\"generation\")),hAfterWrong=await headM(sqlite);mutTests.push({name:\"wrong_lease_generation_rejected_without_mutation\",pass:wrong.reason===\"STALE_LEASE_GENERATION\"&&gBeforeWrong===gAfterWrong&&hBeforeWrong===hAfterWrong,detail:wrong});\nawait sqlite.execute({sql:`UPDATE ${P}tasks SET lease_expires_at='2000-01-01T00:00:00+00:00' WHERE id=?`,args:[c1.task_id]});const expiredCommit=await commitM(aid,c1.task_id,c1.workstream_generation,c1.lease_generation,{probe:\"expired\"});mutTests.push({name:\"expired_commit_rejected\",pass:expiredCommit.reason===\"LEASE_EXPIRED\",detail:expiredCommit});\nconst rec=await recoverM();mutTests.push({name:\"recover_stale\",pass:rec.recovered.includes(c1.task_id),detail:rec});\n// Isolated fault-injection fixture: force the recovered original task to the front so ABA tests the same task/incarnation identity.\nawait sqlite.execute({sql:`UPDATE ${P}tasks SET priority=1000000000000000 WHERE id=?`,args:[c1.task_id]});\nconst c2:any=await claimM(aid,\"PROCESS\",900);mutTests.push({name:\"reclaim_after_recovery_new_generation\",pass:!!c2.ok&&c2.task_id===c1.task_id&&c2.lease_generation>c1.lease_generation,detail:c2});\nconst staleOld=await commitM(aid,c2.task_id,c2.workstream_generation,c1.lease_generation,{probe:\"old-incarnation\"});mutTests.push({name:\"old_incarnation_rejected\",pass:staleOld.reason===\"STALE_LEASE_GENERATION\",detail:staleOld});\nconst correct=await commitM(aid,c2.task_id,c2.workstream_generation,c2.lease_generation,{probe:\"current-incarnation\",source:\"isolated-shadow\"});mutTests.push({name:\"current_incarnation_commit\",pass:correct.ok===true,detail:correct});\nconst endEvents=(await sqlite.execute(`SELECT id,event_uuid,ts,workstream,agent_id,task_id,type,payload_json,prev_hash,event_hash FROM ${P}events ORDER BY id`)).rows as any[];const endVerify=await verifyEvents(endEvents);const endHead=await headM(sqlite);mutTests.push({name:\"full_event_chain_after_mutations\",pass:endVerify.pass&&endVerify.computed_head===endHead,detail:{events:endEvents.length,head:endHead}});\nconst allPass=mutTests.every(x=>x.pass);\nconsole.log(JSON.stringify({schema:\"BRAIN_VAL_NATIVE_MUTATION_SLICE_V1_CANDIDATE\",classification:\"NONAUTHORITY_SHADOW_ONLY\",source_snapshot:SNAP,source_generation:s.generation,brain_sha256:brain.sha256,semantic_scope:[\"register-agent\",\"claim\",\"recover-stale\",\"commit-COMPLETE\"],intentional_hardening:[\"commit requires exact lease_generation\"],unsupported_for_production:[\"INVALID/BLOCKED propagation parity\",\"renew-lease exact-incarnation fencing\",\"authority cutover/single-writer promotion\",\"latest-generation import/replay\"],tests:mutTests,chain:endVerify,canonical_brain_mutation:false,bridge_table_mutation:false,production_routing:false,direct_sprites:false,human_authority_approval:false,pass:allPass},null,2));","deleted",false,"label",[47,24],"capacity","29a70aaf-cb5b-45b6-9fd3-d04be7430cbd",["D",1789174188714],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","R3A4 cohort repair isolated qualification","imageUrl","userId","6be0fc5c-1fef-4bd6-a1e1-67a3f8c0764e","pinnedFileId","01a09317-8b36-757f-b18a-5477cfa017af","pinPreview","pinMigrated","screenshotVersion","likeCount","orgId","01a0715b-703f-741f-ab35-c85020e4a5e0","tursoName","29a70aafcb5b45b69fd3d04be7430cbd","tursoHostname","29a70aafcb5b45b69fd3d04be7430cbd-val-town.aws-us-east-2.turso.io","tursoMeasuredAt",["D",1789522836959],"pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_9":10,"_107":103},"org",{"_9":10,"_100":101,"_102":103,"_58":59,"_104":105,"_106":44},"branch",{"_37":32,"_11":91,"_22":30,"_92":48,"_93":-5,"_94":-5,"_95":-5,"_96":-5,"_97":-5,"_98":12,"_99":10},"isOwned","main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","displayName","Mo Sadek","avatar","https://lh3.googleusercontent.com/a/ACg8ocL1eT_LHhKSg5px3nXIO6eez79aZXef466qXKh2gak-0iwrvw=s96-c","tier","free","canRestrictVals","profileImageUrl","ctx",{"_84":-5,"_141":142,"_143":144,"_145":146,"_147":44,"_148":44,"_149":44,"_150":34,"_151":-5,"_152":-7,"_153":-7,"_154":38,"_155":44,"_156":44,"_157":-5,"_158":44,"_159":44,"_160":44,"_161":-5},"ENV",{"_112":113,"_114":115,"_116":91,"_117":118,"_119":120,"_121":122,"_123":124,"_125":126,"_127":128,"_129":130,"_131":132,"_133":134,"_135":136,"_137":138,"_139":140},"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","orgs",[],"preferencesKeybindings","default","preferencesTheme","light","preferencesFixers","preferencesCopilot","preferencesSelectionAi","preferencesCloseBrackets","preferencesChatPanelState","preferencesDprint","preferencesDenofmt","notificationCount","flagDenols","isBusinessOrgMember","businessOrgHandle","isBusinessOrgAdmin","isHigherTownieTier","navCollapsed","currentOrgId"]