[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8},"actionData","errors","root",{"_109":110,"_111":112},"routes/embed.x.$handle.$name.$",{"_9":10,"_11":12,"_13":14,"_15":16,"_17":18,"_19":20,"_21":-5},"handle","mosadek","name","r3a3-m6q9-shadow2","path","capacity/val_native_mut_v4_propagation_shadow.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/r3a3-m6q9-shadow2/code/capacity/val_native_mut_v4_propagation_shadow.ts","extension","id","12ab4f0d-0c2d-4b14-acb8-701bc05a6db0","val_native_mut_v4_propagation_shadow.ts","fileId","01a092e7-153a-764e-9cee-74e7c54d9da8","parentId","01a092e7-153a-764e-9cee-8e1fd2bf1108","branchId","1da4df5d-ade5-4da9-8efa-00b2d8f1294a","branchVersion",1,"latest",true,"createdAt",["D",1789171012789],"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 _snaps:any[]=await blob.list(\"snapshots/brain_snapshot_g\");\nconst _gen=(k:string)=>Number(k.match(/^snapshots\\/brain_snapshot_g(\\d+)_/)?.[1]||-1);\n_snaps.sort((a,b)=>_gen(b.key)-_gen(a.key));\nif(!_snaps[0]) throw new Error(\"NO_SNAPSHOT\");\nconst SNAP=String(_snaps[0].key);\nconst EXPECT_BRAIN_SHA=\"8f463c630e7c3836c767ec0feea7d40bd774a10bb5f60a193bc5bbd4d9b1ed9c\";\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\");\n// Latest-snapshot shadow: event-chain integrity + embedded recovery-file hashes are the authority-neutral integrity gates.\n// Raw snapshot SHA is reported but not pinned to a historical generation.\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=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 renewM(aid:string,taskId:string,expectedLeaseGen:number,seconds=900){if(seconds<60||seconds>7200)throw new Error(\"LEASE_SECONDS_OUT_OF_RANGE\");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];if(!task)throw new Error(\"UNKNOWN_TASK\");if(task.state!==\"LEASED\"||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_RECOVER_REQUIRED\",lease_expires_at:task.lease_expires_at}}const exp=new Date(Date.now()+seconds*1000).toISOString().replace(\"Z\",\"+00:00\"),t=isoNow();await tx.execute({sql:`UPDATE ${P}tasks SET lease_expires_at=?,updated_at=? WHERE id=? AND state='LEASED' AND lease_owner=? AND lease_generation=?`,args:[exp,t,taskId,aid,expectedLeaseGen]});await tx.execute({sql:`UPDATE ${P}agents SET last_seen=? WHERE id=?`,args:[t,aid]});await tx.commit();return{ok:true,task_id:taskId,lease_generation:expectedLeaseGen,lease_expires_at:exp,generation:await genM(sqlite),semantic_generation_unchanged:true}}catch(e){await tx.rollback();throw e}}\nasync function terminalDependencyFailuresM(c:any,row:any){\n const out:any[]=[];\n for(const d of JSON.parse(String(row.depends_json||\"[]\"))){\n const r:any=await c.execute({sql:`SELECT workstream,state FROM ${P}tasks WHERE id=?`,args:[d]});const x=r.rows?.[0];\n if(!x)out.push({id:d,state:\"MISSING\"});\n else if(String(x.workstream)!==String(row.workstream))out.push({id:d,state:\"CROSS_WORKSTREAM\"});\n else if([\"INVALID\",\"BLOCKED\"].includes(String(x.state)))out.push({id:d,state:String(x.state)});\n }\n return out.sort((a,b)=>String(a.id).localeCompare(String(b.id))||String(a.state).localeCompare(String(b.state)));\n}\nasync function terminalGuardFailuresM(c:any,row:any){\n const out:any[]=[];\n for(const g of JSON.parse(String(row.guards_json||\"[]\"))){\n const typ=String(g.type||\"\");\n if(typ===\"task_complete\"){\n const id=String(g.id||\"\");const r:any=await c.execute({sql:`SELECT workstream,state FROM ${P}tasks WHERE id=?`,args:[id]});const x=r.rows?.[0];\n if(!x)out.push({type:typ,id,state:\"MISSING\"});\n else if(String(x.workstream)!==String(row.workstream))out.push({type:typ,id,state:\"CROSS_WORKSTREAM\"});\n else if([\"INVALID\",\"BLOCKED\"].includes(String(x.state)))out.push({type:typ,id,state:String(x.state)});\n }else if(typ===\"claim_verified\"){\n const id=String(g.id||\"\");const r:any=await c.execute({sql:`SELECT workstream,status FROM ${P}claims WHERE id=?`,args:[id]});const x=r.rows?.[0];\n if(!x)out.push({type:typ,id,status:\"MISSING\"});\n else if(String(x.workstream)!==String(row.workstream))out.push({type:typ,id,status:\"CROSS_WORKSTREAM\"});\n else if([\"FALSIFIED\",\"STALE\"].includes(String(x.status)))out.push({type:typ,id,status:String(x.status)});\n }\n }\n return out.sort((a,b)=>canonJs(a).localeCompare(canonJs(b)));\n}\nasync function terminalCausalBlockersM(c:any,row:any){return{dependencies:await terminalDependencyFailuresM(c,row),guards:await terminalGuardFailuresM(c,row)}}\nasync function propagateImpossibleReadyTasksM(c:any,ws:string,agentId:string|null,rootCause:any){\n const changed:any[]=[];\n while(true){\n const round:any[]=[];const q:any=await c.execute({sql:`SELECT * FROM ${P}tasks WHERE workstream=? AND state='READY' ORDER BY id`,args:[ws]});\n for(const r of q.rows||[]){\n const blockers=await terminalCausalBlockersM(c,r);if(!blockers.dependencies.length&&!blockers.guards.length)continue;\n const eventType=blockers.dependencies.length&&!blockers.guards.length?\"TASK_DEPENDENCY_BLOCKED\":\"TASK_CAUSALLY_BLOCKED\";\n const payload=eventType===\"TASK_DEPENDENCY_BLOCKED\"?{blocking_dependencies:blockers.dependencies,root_terminal_task:(rootCause&&rootCause.task_id)||blockers.dependencies[0].id}:{blocking_dependencies:blockers.dependencies,blocking_guards:blockers.guards,root_cause:rootCause};\n const ev=await eventM(c,ws,agentId,r.id,eventType,payload);const t=isoNow();\n const u:any=await c.execute({sql:`UPDATE ${P}tasks SET state='BLOCKED',result_event_id=?,updated_at=?,lease_owner=NULL,lease_mode=NULL,lease_generation=NULL,lease_expires_at=NULL WHERE id=? AND state='READY' RETURNING id`,args:[ev.id,t,r.id]});\n if(u.rows?.[0]){const item={task_id:r.id,event_id:ev.id,blocking_dependencies:blockers.dependencies,blocking_guards:blockers.guards};round.push(item);changed.push(item)}\n }\n if(!round.length)break;\n }\n return changed;\n}\nasync function commitM(aid:string,taskId:string,expectedWsGen:number,expectedLeaseGen:number,payload:any,state=\"COMPLETE\"){\n if(![\"COMPLETE\",\"INVALID\",\"BLOCKED\"].includes(state))throw new Error(\"BAD_COMMIT_STATE\");\n const tx=await(sqlite as any).transaction(\"write\");\n try{\n const tr:any=await tx.execute({sql:`SELECT * FROM ${P}tasks WHERE id=?`,args:[taskId]});const task=tr.rows?.[0];\n const ar:any=await tx.execute({sql:`SELECT * FROM ${P}agents WHERE id=?`,args:[aid]});const ag=ar.rows?.[0];\n if(!task||!ag)throw new Error(\"UNKNOWN_TASK_OR_AGENT\");\n if(task.workstream!==ag.workstream){await tx.rollback();return{ok:false,reason:\"CROSS_WORKSTREAM_COMMIT_FORBIDDEN\"}}\n if(task.lease_owner!==aid){await tx.rollback();return{ok:false,reason:\"NOT_LEASE_OWNER\"}}\n if(Number(task.lease_generation)!==expectedLeaseGen){await tx.rollback();return{ok:false,reason:\"STALE_LEASE_GENERATION\",actual:Number(task.lease_generation),expected:expectedLeaseGen}}\n if(expired(task.lease_expires_at)){await tx.rollback();return{ok:false,reason:\"LEASE_EXPIRED\"}}\n 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);\n if(actual!==expectedWsGen){await tx.rollback();return{ok:false,reason:\"STALE_WORKSTREAM_WRITE\",actual,expected:expectedWsGen}}\n const ev=await eventM(tx,task.workstream,aid,taskId,\"TASK_RESULT_COMMITTED\",payload);const t=isoNow();\n const u:any=await tx.execute({sql:`UPDATE ${P}tasks SET state=?,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:[state,ev.id,t,taskId,aid]});\n if(!u.rows?.[0])throw new Error(\"COMMIT_TASK_UPDATE_RACE\");\n const propagated=[\"INVALID\",\"BLOCKED\"].includes(state)?await propagateImpossibleReadyTasksM(tx,String(task.workstream),aid,{type:\"task_terminal\",task_id:taskId,state}):[];\n 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]});\n await tx.commit();return{ok:true,generation:ng,event_id:ev.id,propagated_blocked:propagated,state};\n }catch(e){await tx.rollback();throw e}\n}\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[]=[];const owners=new Set();for(const r of rs){const old=String(r.lease_owner||\"\");const 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||null});if(old)owners.add(old);rec.push(String(r.id))}for(const old of owners){const held:any=await tx.execute({sql:`SELECT 1 ok FROM ${P}tasks WHERE state='LEASED' AND lease_owner=? LIMIT 1`,args:[old]});if(!held.rows?.[0])await tx.execute({sql:`UPDATE ${P}agents SET status='READY',last_seen=? WHERE id=?`,args:[isoNow(),old]})}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,owners_checked:[...owners].sort()}}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();const ownerAfterBasic:any=(await sqlite.execute({sql:`SELECT status FROM ${P}agents WHERE id=?`,args:[aid]})).rows?.[0];mutTests.push({name:\"recover_stale_owner_ready_parity\",pass:rec.recovered.includes(c1.task_id)&&String(ownerAfterBasic?.status)===\"READY\",detail:{rec,owner_status:ownerAfterBasic?.status}});\n// Recovery-parity regression: multiple expired leases owned by one WORKING agent must recover together and leave the owner READY.\nconst aidMulti=\"sat-shadow-recover-multi-v2\",t0=isoNow();await sqlite.execute({sql:`INSERT INTO ${P}agents(id,parent_id,type,workstream,role,status,boot_generation,last_generation,last_seen,capabilities_json) VALUES(?,?,?,?,?,'WORKING',?,?,?,?)`,args:[aidMulti,null,\"PROCESS\",\"global\",\"recovery-parity-fixture\",await genM(sqlite),await genM(sqlite),t0,\"[]\"]});\nfor(const id of [\"sat-shadow-expired-a-v2\",\"sat-shadow-expired-b-v2\"])await sqlite.execute({sql:`INSERT INTO ${P}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) VALUES(?,?,'LEASED',0,'[]','fixture','fixture','{}',?,'PROCESS',77,'2000-01-01T00:00:00+00:00',?,?,NULL,'[]',?,NULL,NULL,'[]','[]')`,args:[id,\"global\",aidMulti,t0,t0,\"fixture:\"+id]});\nconst recMulti=await recoverM();const multiStatus:any=(await sqlite.execute({sql:`SELECT status FROM ${P}agents WHERE id=?`,args:[aidMulti]})).rows?.[0];mutTests.push({name:\"multiple_expired_same_owner_ready\",pass:[\"sat-shadow-expired-a-v2\",\"sat-shadow-expired-b-v2\"].every(x=>recMulti.recovered.includes(x))&&String(multiStatus?.status)===\"READY\",detail:{rec:recMulti,status:multiStatus?.status}});\n// Recovery-parity regression: if the same owner still holds a live lease, recovering another expired lease must preserve WORKING.\nawait sqlite.execute({sql:`UPDATE ${P}agents SET status='WORKING' WHERE id=?`,args:[aidMulti]});const tf=isoNow();for(const [id,exp] of [[\"sat-shadow-expired-c-v2\",\"2000-01-01T00:00:00+00:00\"],[\"sat-shadow-live-d-v2\",new Date(Date.now()+3600000).toISOString().replace(\"Z\",\"+00:00\")]])await sqlite.execute({sql:`INSERT INTO ${P}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) VALUES(?,?,'LEASED',0,'[]','fixture','fixture','{}',?,'PROCESS',88,?,?,?,NULL,'[]',?,NULL,NULL,'[]','[]')`,args:[id,\"global\",aidMulti,exp,tf,tf,\"fixture:\"+id]});\nconst recLive=await recoverM();const liveStatus:any=(await sqlite.execute({sql:`SELECT status FROM ${P}agents WHERE id=?`,args:[aidMulti]})).rows?.[0];mutTests.push({name:\"owner_with_other_live_lease_stays_working\",pass:recLive.recovered.includes(\"sat-shadow-expired-c-v2\")&&!recLive.recovered.includes(\"sat-shadow-live-d-v2\")&&String(liveStatus?.status)===\"WORKING\",detail:{rec:recLive,status:liveStatus?.status}});\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 beforeRenew:any=(await sqlite.execute({sql:`SELECT lease_expires_at FROM ${P}tasks WHERE id=?`,args:[c2.task_id]})).rows?.[0];const staleRenew=await renewM(aid,c2.task_id,c1.lease_generation,1800);const afterStaleRenew:any=(await sqlite.execute({sql:`SELECT lease_expires_at FROM ${P}tasks WHERE id=?`,args:[c2.task_id]})).rows?.[0];mutTests.push({name:\"old_incarnation_renew_rejected_without_extension\",pass:staleRenew.reason===\"STALE_LEASE_GENERATION\"&&String(afterStaleRenew?.lease_expires_at)===String(beforeRenew?.lease_expires_at),detail:{staleRenew,before:beforeRenew?.lease_expires_at,after:afterStaleRenew?.lease_expires_at}});\nconst currentRenew=await renewM(aid,c2.task_id,c2.lease_generation,1800);const afterCurrentRenew:any=(await sqlite.execute({sql:`SELECT lease_expires_at FROM ${P}tasks WHERE id=?`,args:[c2.task_id]})).rows?.[0];mutTests.push({name:\"current_incarnation_renew_succeeds_generation_unchanged\",pass:currentRenew.ok===true&¤tRenew.semantic_generation_unchanged===true&&String(afterCurrentRenew?.lease_expires_at)===String(currentRenew.lease_expires_at)&&Number(currentRenew.generation)===Number(c2.workstream_generation),detail:currentRenew});\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});\n// INVALID/BLOCKED propagation parity fixture: one root terminalizes dependency descendants plus task/claim guards, while unrelated work stays READY.\nconst fixtureNow=isoNow(),fixtureLeaseGen=await genM(sqlite),fixtureExp=new Date(Date.now()+3600000).toISOString().replace(\"Z\",\"+00:00\");\nconst root=\"sat-prop-root-v4\",dep=\"sat-prop-dep-v4\",grand=\"sat-prop-grand-v4\",guard=\"sat-prop-guard-v4\",claimGuard=\"sat-prop-claimguard-v4\",unrelated=\"sat-prop-unrelated-v4\",claimId=\"sat-prop-falsified-claim-v4\";\nconst insTask=async(id:string,state:string,depends:string[],guards:any[],leaseOwner:string|null=null,leaseGen:number|null=null,leaseExp:string|null=null)=>sqlite.execute({sql:`INSERT INTO ${P}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) VALUES(?,? ,?,0,?,'fixture','fixture','{}',?,'PROCESS',?,?,?, ?,NULL,'[]',?,NULL,NULL,'[]',?)`,args:[id,\"global\",state,canonJs(depends),leaseOwner,leaseGen,leaseExp,fixtureNow,fixtureNow,\"fixture:\"+id,canonJs(guards)]});\nawait sqlite.execute({sql:`INSERT INTO ${P}claims(id,workstream,status,statement_json,statement_sha256,evidence_json,created_generation,invalidated_by,created_at,updated_at) VALUES(?,?,'FALSIFIED','{}',?,'[]',?,NULL,?,?)`,args:[claimId,\"global\",\"0\".repeat(64),fixtureLeaseGen,fixtureNow,fixtureNow]});\nawait insTask(root,\"LEASED\",[],[],aid,fixtureLeaseGen,fixtureExp);await insTask(dep,\"READY\",[root],[]);await insTask(grand,\"READY\",[dep],[]);await insTask(guard,\"READY\",[],[{type:\"task_complete\",id:root}]);await insTask(claimGuard,\"READY\",[],[{type:\"claim_verified\",id:claimId}]);await insTask(unrelated,\"READY\",[],[]);\nawait sqlite.execute({sql:`UPDATE ${P}agents SET status='WORKING' WHERE id=?`,args:[aid]});\nconst propWsGen=Number((await sqlite.execute(`SELECT head_generation FROM ${P}workstreams WHERE id='global'`)).rows[0].head_generation);\nconst invalidCommit=await commitM(aid,root,propWsGen,fixtureLeaseGen,{probe:\"terminal-propagation\"},\"INVALID\");\nconst propRows:any=(await sqlite.execute({sql:`SELECT id,state,result_event_id FROM ${P}tasks WHERE id IN (?,?,?,?,?,?) ORDER BY id`,args:[root,dep,grand,guard,claimGuard,unrelated]})).rows;\nconst propState=Object.fromEntries(propRows.map((r:any)=>[r.id,r.state]));\nconst propEvents:any=(await sqlite.execute({sql:`SELECT task_id,type,payload_json FROM ${P}events WHERE task_id IN (?,?,?,?) AND type IN ('TASK_DEPENDENCY_BLOCKED','TASK_CAUSALLY_BLOCKED') ORDER BY id`,args:[dep,grand,guard,claimGuard]})).rows;\nconst terminalSet=new Set((invalidCommit.propagated_blocked||[]).map((x:any)=>String(x.task_id)));\nmutTests.push({name:\"invalid_commit_transitive_negative_causality\",pass:invalidCommit.ok===true&&invalidCommit.state===\"INVALID\"&&propState[root]===\"INVALID\"&&propState[dep]===\"BLOCKED\"&&propState[grand]===\"BLOCKED\"&&propState[guard]===\"BLOCKED\"&&propState[claimGuard]===\"BLOCKED\"&&propState[unrelated]===\"READY\"&&[dep,grand,guard,claimGuard].every(x=>terminalSet.has(x))&&propEvents.filter((x:any)=>x.type===\"TASK_DEPENDENCY_BLOCKED\").length===2&&propEvents.filter((x:any)=>x.type===\"TASK_CAUSALLY_BLOCKED\").length===2,detail:{commit:invalidCommit,states:propState,events:propEvents}});\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_V4_PROPAGATION_CANDIDATE\",classification:\"NONAUTHORITY_SHADOW_ONLY\",source_snapshot:SNAP,source_generation:s.generation,brain_sha256:brain.sha256,semantic_scope:[\"register-agent\",\"claim\",\"renew-lease\",\"recover-stale\",\"commit-COMPLETE\",\"commit-INVALID/BLOCKED\",\"transitive-negative-causality\"],intentional_hardening:[\"commit requires exact lease_generation\",\"renew-lease requires exact lease_generation\"],unsupported_for_production:[\"authority cutover/single-writer promotion\",\"independent second-party reproduction\"],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","04900e5a-0cc1-401b-9ed8-b0fe6196756a",["D",1789171012789],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","Disposable R3A3 exact cohort falsifier","imageUrl","userId","6be0fc5c-1fef-4bd6-a1e1-67a3f8c0764e","pinnedFileId","01a092e7-1539-7581-b5ef-8e522619d4aa","pinPreview","pinMigrated","screenshotVersion","likeCount","orgId","01a0715b-703f-741f-ab35-c85020e4a5e0","tursoName","04900e5a0cc1401b9ed8b0fe6196756a","tursoHostname","04900e5a0cc1401b9ed8b0fe6196756a-val-town.aws-us-east-2.turso.io","tursoMeasuredAt",["D",1789522836959],"pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_9":10,"_108":104},"org",{"_9":10,"_101":102,"_103":104,"_58":59,"_105":106,"_107":44},"branch",{"_37":91,"_11":92,"_22":30,"_93":48,"_94":-5,"_95":-5,"_96":-5,"_97":-5,"_98":-5,"_99":12,"_100":10},"isOwned",2,"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,"_142":143,"_144":145,"_146":147,"_148":44,"_149":44,"_150":44,"_151":34,"_152":-5,"_153":-7,"_154":-7,"_155":38,"_156":44,"_157":44,"_158":-5,"_159":44,"_160":44,"_161":44,"_162":-5},"ENV",{"_113":114,"_115":116,"_117":92,"_118":119,"_120":121,"_122":123,"_124":125,"_126":127,"_128":129,"_130":131,"_132":133,"_134":135,"_136":137,"_138":139,"_140":141},"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"]