[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_175":176,"_177":178},"routes/_app.x.$handle.$name",{"_11":12,"_13":14,"_15":-7,"_18":19,"_17":-7,"_133":-5,"_20":134,"_22":135,"_136":137,"_138":139,"_25":140,"_24":-5,"_141":-5,"_142":-5,"_143":54,"_144":145,"_146":54,"_147":-5,"_148":-5,"_149":150},"routes/_app.x.$handle.$name.code.$",{"_11":12,"_13":14,"_15":16,"_17":-7,"_18":19,"_20":21,"_22":23,"_24":-7,"_25":26,"_27":-5,"_28":-5,"_29":-5,"_30":-5,"_31":-5},"handle","mosadek","name","capacity-v5r2-compile-2012","branchName","main","version","path","","project",{"_34":74,"_13":14,"_46":75,"_76":-5,"_77":54,"_78":79,"_80":79,"_81":82,"_83":-5,"_84":85,"_86":-5,"_87":54,"_88":-5,"_89":-5,"_90":91,"_92":93,"_94":95,"_96":97,"_98":99,"_100":-5,"_101":102,"_103":102,"_104":105,"_106":105,"_107":105,"_108":102,"_109":102,"_110":111,"_112":113,"_114":115,"_116":54},"tree",[65,66],"file","contents",[32,33],"upstream","pull","ahead","behind","envVars",{"_34":57,"_13":58,"_37":59,"_39":-5,"_40":41,"_42":60,"_44":45,"_46":61,"_17":62,"_49":50,"_51":63,"_53":54,"_55":-5,"_18":64},{"_34":35,"_13":36,"_37":38,"_39":-5,"_40":41,"_42":43,"_44":45,"_46":47,"_17":48,"_49":50,"_51":52,"_53":54,"_55":-5,"_18":56},"id","d98c7ca8-96fc-46e8-bba3-be02eb0a2b04","runtime_regression.ts","fileId","ebec773c-aae9-11f1-ad8f-1607ee4eb77e","parentId","branchId","c32bed25-9a9d-40ba-bc65-f61c6e0cea31","branchVersion",10,"latest",true,"createdAt",["D",1788806136933],1,"fileType","script","content","import { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\nimport { blob } from \"https://esm.town/v/std/blob/main.ts\";\nimport controller from \"./candidate.ts\";\nconst T=[\"agent_fabric_samples\",\"agent_fabric_tickets\",\"agent_fabric_substrates\",\"agent_fabric_execution_heartbeats\",\"brain_control_plane_authority_v1\",\"brain_bridge_workers_v4\",\"brain_bridge_jobs\",\"val_native_executor_runtime_v1\",\"brainvn_epoch_meta\",\"brainvn_tasks\",\"brainvn_agents\",\"brainvn_claims\",\"brainvn_artifacts\"];\nasync function reset({claims=true}={claims:true}){\n for(const t of T) await sqlite.execute(\"DROP TABLE IF EXISTS \"+t);\n await sqlite.execute(\"CREATE TABLE brain_control_plane_authority_v1(id INTEGER PRIMARY KEY,epoch INTEGER,writer TEXT,source_generation INTEGER,source_head TEXT,mode TEXT,prepared_at TEXT,updated_at TEXT)\");\n await sqlite.execute(\"CREATE TABLE brain_bridge_workers_v4(worker_id TEXT,instance_id TEXT,last_poll_at TEXT,last_result_at TEXT)\");\n await sqlite.execute(\"CREATE TABLE brain_bridge_jobs(state TEXT,lease_expires_at TEXT)\");\n await sqlite.execute(\"CREATE TABLE val_native_executor_runtime_v1(id TEXT PRIMARY KEY,worker_id TEXT,instance_id TEXT,authority_epoch INTEGER,state TEXT,tick_at TEXT,expires_at TEXT)\");\n await sqlite.execute(\"CREATE TABLE brainvn_epoch_meta(id INTEGER PRIMARY KEY,generation INTEGER)\");\n await sqlite.execute(\"CREATE TABLE brainvn_tasks(id TEXT PRIMARY KEY,workstream TEXT,state TEXT,priority REAL,dedupe_key TEXT,context_manifest TEXT,requires_json TEXT,depends_json TEXT,guards_json TEXT,writes_json TEXT,assigned_agent TEXT,lease_owner TEXT)\");\n await sqlite.execute(\"CREATE TABLE brainvn_agents(id TEXT PRIMARY KEY,workstream TEXT,last_seen TEXT,capabilities_json TEXT)\");\n if(claims) await sqlite.execute(\"CREATE TABLE brainvn_claims(id TEXT PRIMARY KEY,workstream TEXT,status TEXT)\");\n await sqlite.execute(\"CREATE TABLE brainvn_artifacts(sha256 TEXT,task_id TEXT,producer_agent TEXT)\");\n await sqlite.execute(\"CREATE TABLE agent_fabric_execution_heartbeats(instance_id TEXT PRIMARY KEY,provider_id TEXT NOT NULL,brain_agent_id TEXT,workstream TEXT,capabilities_json TEXT NOT NULL,state TEXT NOT NULL,started_at TEXT NOT NULL,heartbeat_at TEXT NOT NULL,expires_at TEXT NOT NULL,metadata_json TEXT NOT NULL)\");\n const n=new Date(),e=new Date(n.getTime()+600000);\n await sqlite.execute({sql:\"INSERT INTO brain_control_plane_authority_v1 VALUES(1,2,'val_native',0,'head','ACTIVE',?,?)\",args:[n.toISOString(),n.toISOString()]});\n await sqlite.execute({sql:\"INSERT INTO val_native_executor_runtime_v1 VALUES('val-native-executor','w','i',2,'RUNNING',?,?)\",args:[n.toISOString(),e.toISOString()]});\n await sqlite.execute(\"INSERT INTO brainvn_epoch_meta VALUES(1,1000)\");\n}\nasync function gen(g:number){await sqlite.execute({sql:\"UPDATE brainvn_epoch_meta SET generation=? WHERE id=1\",args:[g]})}\nasync function task(id:string,p:any={}){\n const x={workstream:\"global\",state:\"READY\",priority:100,dedupe_key:\"d:\"+id,context_manifest:\"{}\",requires_json:\"[]\",depends_json:\"[]\",guards_json:\"[]\",writes_json:\"[]\",assigned_agent:null,lease_owner:null,...p};\n await sqlite.execute({sql:\"INSERT INTO brainvn_tasks VALUES(?,?,?,?,?,?,?,?,?,?,?,?)\",args:[id,x.workstream,x.state,x.priority,x.dedupe_key,x.context_manifest,x.requires_json,x.depends_json,x.guards_json,x.writes_json,x.assigned_agent,x.lease_owner]});\n}\nasync function agent(id:string,caps:any=[\"alpha\"],last?:string){await sqlite.execute({sql:\"INSERT INTO brainvn_agents VALUES(?,?,?,?)\",args:[id,\"global\",last||new Date().toISOString(),typeof caps===\"string\"?caps:JSON.stringify(caps)]})}\nasync function hb(id:string,caps=[\"alpha\"]){const n=new Date(),e=new Date(n.getTime()+600000);await sqlite.execute({sql:\"INSERT INTO agent_fabric_execution_heartbeats VALUES(?,?,?,?,?,'RUNNING',?,?,?,?)\",args:[\"hb:\"+id,\"test\",id,\"global\",JSON.stringify(caps),n.toISOString(),n.toISOString(),e.toISOString(),\"{}\"]})}\nasync function ticketTable(){await sqlite.execute(\"CREATE TABLE IF NOT EXISTS agent_fabric_tickets(id TEXT PRIMARY KEY,kind TEXT NOT NULL,workstream TEXT,task_id TEXT,required_caps_json TEXT NOT NULL,desired_instances INTEGER NOT NULL,priority REAL NOT NULL,state TEXT NOT NULL,reason TEXT NOT NULL,created_at TEXT NOT NULL,updated_at TEXT NOT NULL)\")}\nasync function sentinel(){await ticketTable();const n=new Date().toISOString();await sqlite.execute({sql:\"INSERT INTO agent_fabric_tickets VALUES('SENTINEL','PROVISION_MORE','global',NULL,'[]',9,1,'OPEN','prior-good',?,?)\",args:[n,n]})}\nasync function tickets(){const r:any=await sqlite.execute(\"SELECT id,state,desired_instances,kind FROM agent_fabric_tickets ORDER BY id\");return r.rows||[]}\nfunction ok(v:any,m:string){if(!v)throw new Error(\"ASSERT:\"+m)}\nconst R:any[]=[];async function test(n:string,f:()=>Promise){try{await f();R.push({name:n,ok:true})}catch(e){R.push({name:n,ok:false,error:e instanceof Error?e.message:String(e)})}}\n\ntry{await blob.delete(\"snapshots/brain_snapshot_g50_synthetic.json\")}catch{}\nawait test(\"healthy live path requires no snapshot\",async()=>{await reset();await gen(1001);await task(\"one\");const o:any=await controller();ok(o.observed.decision_state_source===\"LIVE_CANONICAL\",\"live\");ok(o.observed.capacity_deficit_instances===1,\"one deficit\");ok(o.snapshot_key===null,\"no snapshot\")});\nawait blob.set(\"snapshots/brain_snapshot_g50_synthetic.json\",JSON.stringify({snapshot:{generation:50,tasks:[],agents:[],claims:[],artifacts:[]}}));\nawait test(\">900-generation stale snapshot stays diagnostic\",async()=>{await reset();await gen(1001);for(let i=0;i<4;i++)await task(\"m\"+i,{priority:100-i});const o:any=await controller();ok(o.observed.decision_generation===1001,\"live g1001\");ok(o.observed.diagnostic_snapshot_generation===50,\"diag g50\");ok(o.observed.capacity_deficit_instances===4,\"many unmatched=4\")});\nawait test(\"live read fault cannot mutate population tickets\",async()=>{await reset({claims:false});await gen(1002);await task(\"x\");await sentinel();const o:any=await controller();ok(o.error===\"LIVE_CANONICAL_DECISION_READ_FAILED_FAIL_CLOSED\",\"failclosed\");const s=(await tickets()).find((x:any)=>x.id===\"SENTINEL\");ok(s?.state===\"OPEN\"&&Number(s.desired_instances)===9,\"sentinel preserved\")});\nawait test(\"malformed causal JSON fails closed\",async()=>{await reset();await gen(1003);await task(\"good\",{writes_json:'[\"g\"]'});await task(\"bad\",{priority:200,depends_json:\"[broken\",writes_json:'[\"b\"]'});const o:any=await controller();ok(o.observed.parallel_frontier_tasks===1,\"only good\");ok(!(await tickets()).some((x:any)=>x.id===\"SPAWN_FOR_TASK:bad\"),\"bad no spawn\")});\nawait test(\"malformed leased writes abort before ticket mutation\",async()=>{await reset();await gen(1004);await sentinel();await task(\"leased\",{state:\"LEASED\",writes_json:\"[broken\",lease_owner:\"busy\"});await task(\"r\");let e=\"\";try{await controller()}catch(x){e=x instanceof Error?x.message:String(x)}ok(e.includes(\"MALFORMED_LEASED_WRITES:leased\"),\"leased failclosed\");ok((await tickets()).find((x:any)=>x.id===\"SENTINEL\")?.state===\"OPEN\",\"sentinel\")});\nawait test(\"zero heartbeat adoption never counts registry identities\",async()=>{await reset();await gen(1005);await agent(\"reg\",[\"alpha\"]);await task(\"a\",{requires_json:'[\"alpha\"]'});const o:any=await controller();ok(o.observed.recent_agent_identities_15m===1,\"recent diagnostic\");ok(o.observed.attested_supply_agents===0,\"attested0\");ok(o.observed.capacity_deficit_instances===1,\"deficit1\")});\nawait test(\"partial heartbeat adoption counts only attested supply\",async()=>{await reset();await gen(1006);await agent(\"live\",[\"alpha\"]);await hb(\"live\",[\"alpha\"]);await agent(\"rowonly\",[\"alpha\"]);await task(\"a\",{requires_json:'[\"alpha\"]',writes_json:'[\"a\"]'});await task(\"b\",{requires_json:'[\"alpha\"]',writes_json:'[\"b\"]'});const o:any=await controller();ok(o.observed.recent_agent_identities_15m===2,\"recent2\");ok(o.observed.attested_supply_agents===1,\"attested1\");ok(o.observed.matched_idle_attested_agents===1,\"matched1\");ok(o.observed.capacity_deficit_instances===1,\"deficit1\");ok(o.observed.supply_metric_mode===\"ATTESTED_ONLY_FAIL_SAFE_DURING_HEARTBEAT_ROLLOUT\",\"truth label\")});\nawait test(\"all-busy attested supply does not suppress READY demand\",async()=>{await reset();await gen(1007);await agent(\"busy\",[\"alpha\"]);await hb(\"busy\",[\"alpha\"]);await task(\"lease\",{state:\"LEASED\",lease_owner:\"busy\",requires_json:'[\"alpha\"]',writes_json:'[\"lock\"]'});for(const id of [\"a\",\"b\",\"c\"])await task(id,{requires_json:'[\"alpha\"]',writes_json:'[\"'+id+'\"]'});const o:any=await controller();ok(o.observed.leased_effective_supply_agents===1,\"busy1\");ok(o.observed.idle_attested_supply_agents===0,\"idle0\");ok(o.observed.capacity_deficit_instances===3,\"deficit3\")});\nawait test(\"excess idle attested supply becomes surplus-work demand\",async()=>{await reset();await gen(1008);for(const id of [\"i1\",\"i2\"]){await agent(id,[\"alpha\"]);await hb(id,[\"alpha\"])}await task(\"only\",{requires_json:'[\"alpha\"]'});const o:any=await controller();ok(o.observed.matched_idle_attested_agents===1,\"matched1\");ok(o.observed.capacity_deficit_instances===0,\"deficit0\");ok(o.observed.idle_blocked_agents===1,\"one surplus\");ok((await tickets()).some((x:any)=>x.id===\"SURPLUS_WORK:global\"&&Number(x.desired_instances)===1),\"surplus ticket\")});\nawait test(\"capability partitions use maximum matching\",async()=>{await reset();await gen(1009);await agent(\"broad\",[\"alpha\",\"beta\"]);await hb(\"broad\",[\"alpha\",\"beta\"]);await agent(\"alpha\",[\"alpha\"]);await hb(\"alpha\",[\"alpha\"]);await task(\"ta\",{requires_json:'[\"alpha\"]',writes_json:'[\"a\"]'});await task(\"tb\",{requires_json:'[\"beta\"]',writes_json:'[\"b\"]'});const o:any=await controller();ok(o.observed.matched_idle_attested_agents===2,\"maximum matching2\");ok(o.observed.capacity_deficit_instances===0,\"deficit0\")});\nawait test(\"overlapping READY writes count one simultaneous task\",async()=>{await reset();await gen(1010);await task(\"hi\",{priority:200,writes_json:'[\"same\"]'});await task(\"lo\",{priority:100,writes_json:'[\"same\"]'});const o:any=await controller();ok(o.observed.parallel_frontier_tasks===1,\"frontier1\");ok(o.observed.capacity_deficit_instances===1,\"deficit1\")});\nawait test(\"assigned task excluded from generic provisioning\",async()=>{await reset();await gen(1011);await task(\"assigned\",{assigned_agent:\"special\"});const o:any=await controller();ok(o.observed.assigned_parallel_frontier_tasks===1,\"assigned1\");ok(o.observed.generic_parallel_frontier_tasks===0,\"generic0\");ok(o.observed.capacity_deficit_instances===0,\"deficit0\");ok(!(await tickets()).some((x:any)=>String(x.id).startsWith(\"SPAWN_FOR_TASK:assigned\")),\"no generic spawn\")});\nawait test(\"sprite_exec is migration-only\",async()=>{await reset();await gen(1012);await task(\"sprite\",{requires_json:'[\"sprite_exec\"]'});const o:any=await controller();ok(o.observed.legacy_capability_migration_tasks===1,\"legacy1\");ok(o.observed.generic_parallel_frontier_tasks===0,\"generic0\");ok(o.observed.capacity_deficit_instances===0,\"deficit0\");ok((await tickets()).some((x:any)=>x.id===\"MIGRATE_CAPABILITY:sprite\"&&x.kind===\"MIGRATE_OR_REBIND_CAPABILITY\"),\"migration ticket\")});\nawait test(\"blocked dependency excluded\",async()=>{await reset();await gen(1013);await task(\"blocked\",{depends_json:'[\"missing\"]'});const o:any=await controller();ok(o.observed.parallel_frontier_tasks===0,\"frontier0\");ok(o.observed.capacity_deficit_instances===0,\"deficit0\")});\nawait test(\"claim guard accepts verified and rejects stale\",async()=>{await reset();await gen(1014);await sqlite.execute(\"INSERT INTO brainvn_claims VALUES('cv','global','VERIFIED')\");await sqlite.execute(\"INSERT INTO brainvn_claims VALUES('cs','global','STALE')\");await task(\"good\",{guards_json:'[{\"type\":\"claim_verified\",\"id\":\"cv\"}]',writes_json:'[\"g\"]'});await task(\"bad\",{guards_json:'[{\"type\":\"claim_verified\",\"id\":\"cs\"}]',writes_json:'[\"b\"]'});const o:any=await controller();ok(o.observed.parallel_frontier_tasks===1,\"only verified claim\")});\nawait test(\"artifact guard is workstream-local and fail-closed\",async()=>{await reset();await gen(1015);await task(\"producer\",{state:\"COMPLETE\"});await sqlite.execute(\"INSERT INTO brainvn_artifacts VALUES('abc','producer',NULL)\");await task(\"good\",{guards_json:'[{\"type\":\"artifact_present\",\"sha256\":\"abc\"}]',writes_json:'[\"g\"]'});await task(\"bad\",{guards_json:'[{\"type\":\"artifact_present\",\"sha256\":\"missing\"}]',writes_json:'[\"b\"]'});const o:any=await controller();ok(o.observed.parallel_frontier_tasks===1,\"artifact-local only\")});\nawait test(\"malformed and future agent timestamps fail closed\",async()=>{await reset();await gen(1016);const fut=new Date(Date.now()+60000).toISOString();await agent(\"future\",[\"alpha\"],fut);await hb(\"future\",[\"alpha\"]);await agent(\"bad\",[\"alpha\"],\"not-a-time\");await hb(\"bad\",[\"alpha\"]);await task(\"a\",{requires_json:'[\"alpha\"]'});const o:any=await controller();ok(o.observed.recent_agent_identities_15m===0,\"no recent\");ok(o.observed.attested_supply_agents===0,\"no attested\");ok(o.observed.capacity_deficit_instances===1,\"deficit1\")});\nawait test(\"subsecond-future executor tick fails closed\",async()=>{await reset();await gen(1017);const n=new Date(Date.now()+900),e=new Date(Date.now()+600000);await sqlite.execute({sql:\"UPDATE val_native_executor_runtime_v1 SET tick_at=?,expires_at=? WHERE id='val-native-executor'\",args:[n.toISOString(),e.toISOString()]});const o:any=await controller();ok(o.observed?.val_native_runtime_tick_fresh===false,\"future tick not fresh\");ok(o.observed?.canonical_mutation_usable===false,\"mutation fenced\");ok(o.observed?.control_plane_state===\"VAL_NATIVE_RUNTIME_STALE\",\"stale state\")});\nawait test(\"malformed agent capabilities never match\",async()=>{await reset();await gen(1018);await agent(\"bad\",\"[broken\");await hb(\"bad\",[\"alpha\"]);await task(\"a\",{requires_json:'[\"alpha\"]'});const o:any=await controller();ok(o.observed.matched_idle_attested_agents===0,\"no match\");ok(o.observed.capacity_deficit_instances===1,\"deficit1\")});\nawait test(\"generation race aborts ticket actuation and preserves prior tickets\",async()=>{await reset();await gen(1019);await sentinel();await task(\"r\");const s:any=sqlite as any;const orig=s.transaction.bind(s);let inject=false;try{s.transaction=async(mode:any)=>{if(mode===\"write\"&&!inject){inject=true;await sqlite.execute(\"UPDATE brainvn_epoch_meta SET generation=generation+1 WHERE id=1\")}return await orig(mode)};const o:any=await controller();ok(o.error===\"CAPACITY_DECISION_GENERATION_CHANGED_RECOMPUTE_REQUIRED\",\"generation fence\");ok((await tickets()).find((x:any)=>x.id===\"SENTINEL\")?.state===\"OPEN\",\"sentinel\")}finally{s.transaction=orig}});\nconst F=R.filter(x=>!x.ok);console.log(JSON.stringify({ok:F.length===0,count:R.length,failed:F.length,results:R},null,2));if(F.length)throw new Error(\"V5R4_REGRESSION_FAILED:\"+F.map(x=>x.name).join(\",\"));\n","deleted",false,"label",[36],"fe612124-d701-4a17-8703-f146d9bfa354","candidate.ts","c48c5a9a-aae9-11f1-aa1e-1607ee4eb77e",9,["D",1788806135046],2,"import { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\nimport { blob } from \"https://esm.town/v/std/blob/main.ts\";\n\nconst JP=(s:any)=>typeof s===\"string\"?JSON.parse(s):s;\nconst JA=(s:any)=>{try{const v=JP(s);return Array.isArray(v)?v:null}catch{return null}};\nconst JO=(s:any)=>{try{const v=JP(s);return v&&typeof v===\"object\"&&!Array.isArray(v)?v:null}catch{return null}};\nconst SA=(s:any)=>{const v=JA(s);return v&&v.every((x:any)=>typeof x===\"string\"&&x.length>0)?v:null};\nconst REQ=(t:any)=>{const v=SA(t.requires_json);if(!v)throw new Error(\"FRONTIER_REQUIRES_INVARIANT:\"+String(t.id));return v};\nconst TS=(x:any)=>{const t=Date.parse(String(x||\"\"));return Number.isFinite(t)?t:null};\nconst uniq=(xs:any[])=>[...new Set(xs.map(String))];\n\nconst SUBSTRATES=[\n {id:\"chatgpt_scheduled\",state:\"PROVEN_EXECUTABLE\",hard_zero_spend:true,max_known_slots:5,control:\"native_hourly\",evidence:\"5 active Scheduled Tasks configured in current account\"},\n {id:\"chatgpt_work_event\",state:\"CANDIDATE_ACCOUNT_CONTROL_BOUNDARY\",hard_zero_spend:true,max_known_slots:null,control:\"event_triggered\",evidence:\"eligible plans support event-triggered Work tasks; account receiver/control still unproven\"},\n {id:\"codex_factory\",state:\"CANDIDATE_REAL_RUN_REQUIRED\",hard_zero_spend:true,max_known_slots:null,control:\"parallel_agents\",evidence:\"official product supports parallel agents; this account automation path still requires real execution proof\"},\n {id:\"camber\",state:\"FAILED_RUNTIME_REPRODUCED\",hard_zero_spend:true,max_known_slots:0,control:\"cloud_agent\",evidence:\"agent records provision, repeated agents_chat_start returned Failed to start agent run\"},\n {id:\"make_cloud_agents\",state:\"CANDIDATE_REAL_RUN_REQUIRED\",hard_zero_spend:true,max_known_slots:null,control:\"cloud_automation\",evidence:\"not promoted until actual zero-overage run proof\"},\n {id:\"brainbase\",state:\"ECONOMICALLY_DISALLOWED\",hard_zero_spend:false,max_known_slots:0,control:\"managed_agent\",evidence:\"task execution is billable\"},\n {id:\"kilo_internal_cells\",state:\"PROVEN_EXECUTABLE_RATE_GOVERNED\",hard_zero_spend:true,max_known_slots:6,control:\"val_interval_parallel\",evidence:\"15-minute Val cell pump; two immediate 6-way waves completed 12/12 with reported zero-cost accepted attempts; bounded NON_SENSITIVE nonauthority reasoning only\"},\n {id:\"manual_chat\",state:\"EMERGENCY_FALLBACK_ONLY\",hard_zero_spend:true,max_known_slots:0,control:\"human_opened\",evidence:\"normal provisioning decommissioned; protected conversation UI throttles under burst creation and must not be used as the production autoscaler\"}\n];\n\nfunction snapshotMeta(k:string){\n let m=k.match(/^snapshots\\/val_native\\/brain_snapshot_epoch(\\d+)_g(\\d+)_/);\n if(m)return {generation:Number(m[2]),epoch:Number(m[1]),kind:\"val_native\"};\n m=k.match(/^snapshots\\/brain_snapshot_g(\\d+)_/);\n if(m)return {generation:Number(m[1]),epoch:1,kind:\"legacy\"};\n return null;\n}\nasync function latestSnapshot(){\n const [legacy,epoch]:any[]=await Promise.all([\n blob.list(\"snapshots/brain_snapshot_g\"),\n blob.list(\"snapshots/val_native/brain_snapshot_epoch\")\n ]);\n const xs:any[]=[...(legacy||[]),...(epoch||[])].map((x:any)=>({...x,_m:snapshotMeta(String(x.key))})).filter((x:any)=>x._m);\n xs.sort((a:any,b:any)=>b._m.generation-a._m.generation||b._m.epoch-a._m.epoch||String(a.key).localeCompare(String(b.key)));\n if(!xs.length)return null;\n const doc:any=JSON.parse(await(await blob.get(xs[0].key)).text());\n return {key:xs[0].key,doc,meta:xs[0]._m};\n}\n\n\nconst NON_AGENT_CAPS=new Set([\"human_authority_approval\"]);\nfunction artifactBelongsLocal(hash:string,ws:string,artifacts:any[],tasksById:Map,agentsById:Map){\n const a=artifacts.find(x=>String(x.sha256||\"\").toLowerCase()===hash.toLowerCase());\n if(!a)return false;\n if(a.task_id){const t=tasksById.get(String(a.task_id));if(t&&String(t.workstream)===ws)return true}\n if(a.producer_agent){const ag=agentsById.get(String(a.producer_agent));if(ag&&String(ag.workstream)===ws)return true}\n return false;\n}\nfunction structuralReasons(t:any,ctx:any){\n const r:string[]=[];\n if(String(t.state)!==\"READY\")r.push(\"NOT_READY\");\n if(!t.dedupe_key)r.push(\"NO_DEDUPE\");\n const manifest=JO(t.context_manifest);\n if(!manifest)r.push(\"MALFORMED_CONTEXT\");\n else if(manifest.execution_allowed===false)r.push(\"EXECUTION_DISALLOWED\");\n const req=SA(t.requires_json);\n if(!req)r.push(\"MALFORMED_REQUIRES\");\n else if(req.some((x:string)=>NON_AGENT_CAPS.has(x)))r.push(\"NON_AGENT_CAPABILITY\");\n const deps=SA(t.depends_json);\n if(!deps)r.push(\"MALFORMED_DEPENDS\");\n else for(const d of deps){const x=ctx.tasksById.get(String(d));if(!x||String(x.state)!==\"COMPLETE\")r.push(\"DEPENDENCY\")}\n const guards=JA(t.guards_json);\n if(!guards)r.push(\"MALFORMED_GUARDS\");\n else for(const g of guards){\n if(!g||typeof g!==\"object\"||Array.isArray(g)){r.push(\"MALFORMED_GUARDS\");continue}\n if(g.type===\"task_complete\"){const x=ctx.tasksById.get(String(g.id));if(!x||String(x.workstream)!==String(t.workstream)||String(x.state)!==\"COMPLETE\")r.push(\"TASK_GUARD\")}\n else if(g.type===\"claim_verified\"){const x=ctx.claimsById.get(String(g.id));if(!x||String(x.workstream)!==String(t.workstream)||String(x.status)!==\"VERIFIED\")r.push(\"CLAIM_GUARD\")}\n else if(g.type===\"artifact_present\"){if(!artifactBelongsLocal(String(g.sha256||\"\"),String(t.workstream),ctx.artifacts,ctx.tasksById,ctx.agentsById))r.push(\"ARTIFACT_GUARD\")}\n else r.push(\"UNKNOWN_GUARD\");\n }\n const writes=SA(t.writes_json);\n if(!writes)r.push(\"MALFORMED_WRITES\");\n else if(writes.some((w:string)=>ctx.leasedWrites.has(w)))r.push(\"WRITE_LOCK\");\n return uniq(r);\n}\nfunction agentMatches(t:any,a:any){\n if(String(t.workstream)!==String(a.workstream))return false;\n if(t.assigned_agent!==null&&t.assigned_agent!==undefined&&String(t.assigned_agent)!==String(a.id))return false;\n const capList=SA(a.capabilities_json),req=SA(t.requires_json);\n if(!capList||!req)return false;\n const caps=new Set(capList);\n return req.every((x:string)=>caps.has(x));\n}\nfunction recentAgents(agents:any[],nowMs:number,windowMs=15*60*1000){\n return agents.filter(a=>{const t=TS(a.last_seen);return t!==null&&t<=nowMs&&nowMs-t<=windowMs});\n}\nfunction maximumIdleMatching(tasks:any[],agents:any[]){\n const agentToTask=new Map(),taskToAgent=new Map();\n function dfs(t:any,seen:Set){\n for(const a of agents){\n const aid=String(a.id);if(seen.has(aid)||!agentMatches(t,a))continue;seen.add(aid);\n const prior=agentToTask.get(aid);\n if(!prior||dfs(prior,seen)){agentToTask.set(aid,t);taskToAgent.set(String(t.id),a);return true}\n }\n return false;\n }\n for(const t of tasks)dfs(t,new Set());\n return {agentToTask,taskToAgent,matched:taskToAgent.size};\n}\nfunction parallelFrontier(tasks:any[],claims:any[],artifacts:any[],agents:any[]){\n const tasksById=new Map(tasks.map(t=>[String(t.id),t]));\n const claimsById=new Map(claims.map(c=>[String(c.id),c]));\n const agentsById=new Map(agents.map(a=>[String(a.id),a]));\n const leasedWrites=new Set();\n for(const t of tasks.filter(t=>String(t.state)===\"LEASED\")){\n const writes=SA(t.writes_json);\n if(!writes)throw new Error(\"MALFORMED_LEASED_WRITES:\"+String(t.id));\n for(const w of writes)leasedWrites.add(w);\n }\n const acceptedWrites=new Set(),frontier:any[]=[];\n const ctx={tasksById,claimsById,agentsById,artifacts,leasedWrites};\n const ordered=[...tasks].sort((a,b)=>(Number(b.priority)||0)-(Number(a.priority)||0)||String(a.id).localeCompare(String(b.id)));\n for(const t of ordered){\n if(structuralReasons(t,ctx).length)continue;\n const writes=SA(t.writes_json);\n if(!writes)throw new Error(\"FRONTIER_WRITES_INVARIANT:\"+String(t.id));\n if(writes.some((w:string)=>acceptedWrites.has(w)))continue;\n frontier.push(t);for(const w of writes)acceptedWrites.add(w);\n }\n return frontier;\n}\nasync function readCanonicalDecisionState(){\n const tx:any=await (sqlite as any).transaction(\"read\");\n try{\n const m:any=await tx.execute(\"SELECT generation FROM brainvn_epoch_meta WHERE id=1\");\n const t:any=await tx.execute(\"SELECT * FROM brainvn_tasks\");\n const a:any=await tx.execute(\"SELECT * FROM brainvn_agents\");\n const c:any=await tx.execute(\"SELECT * FROM brainvn_claims\");\n const ar:any=await tx.execute(\"SELECT * FROM brainvn_artifacts\");\n const generation=Number(m.rows?.[0]?.generation);\n if(!Number.isInteger(generation))throw new Error(\"LIVE_GENERATION_MISSING\");\n const out={generation,tasks:t.rows||[],agents:a.rows||[],claims:c.rows||[],artifacts:ar.rows||[]};\n await tx.commit();return out;\n }catch(e){try{await tx.rollback()}catch{};throw e}\n}\n\n\nexport default async function(){\n await sqlite.execute({sql:\"CREATE TABLE IF NOT EXISTS agent_fabric_substrates(id TEXT PRIMARY KEY,state TEXT NOT NULL,hard_zero_spend INTEGER NOT NULL,max_known_slots INTEGER,control TEXT NOT NULL,evidence TEXT NOT NULL,updated_at TEXT NOT NULL)\"});\n await sqlite.execute({sql:\"CREATE TABLE IF NOT EXISTS agent_fabric_tickets(id TEXT PRIMARY KEY,kind TEXT NOT NULL,workstream TEXT,task_id TEXT,required_caps_json TEXT NOT NULL,desired_instances INTEGER NOT NULL,priority REAL NOT NULL,state TEXT NOT NULL,reason TEXT NOT NULL,created_at TEXT NOT NULL,updated_at TEXT NOT NULL)\"});\n await sqlite.execute({sql:\"CREATE TABLE IF NOT EXISTS agent_fabric_samples(sampled_at TEXT PRIMARY KEY,snapshot_generation INTEGER,snapshot_key TEXT,recent_agents_15m INTEGER,leased_recent_agents INTEGER,idle_recent_agents INTEGER,structurally_claimable_tasks INTEGER,direct_matchable_tasks INTEGER,unmatched_claimable_tasks INTEGER,idle_matchable_agents INTEGER,idle_blocked_agents INTEGER,open_capacity_tickets INTEGER,state_json TEXT NOT NULL)\"});\n await sqlite.execute({sql:\"CREATE TABLE IF NOT EXISTS agent_fabric_execution_heartbeats(instance_id TEXT PRIMARY KEY,provider_id TEXT NOT NULL,brain_agent_id TEXT,workstream TEXT,capabilities_json TEXT NOT NULL,state TEXT NOT NULL,started_at TEXT NOT NULL,heartbeat_at TEXT NOT NULL,expires_at TEXT NOT NULL,metadata_json TEXT NOT NULL)\"});\n\n const now=new Date(),nowIso=now.toISOString();\n const authRes:any=await sqlite.execute(`\n SELECT epoch,writer,source_generation,source_head,mode,prepared_at,updated_at\n FROM brain_control_plane_authority_v1\n ORDER BY id DESC LIMIT 1`);\n const auth:any=authRes.rows?.[0]||null;\n const writer=String(auth?.writer||\"\");\n const mode=String(auth?.mode||\"\");\n const valNativeSelected=writer===\"val_native\";\n const hostBridgeSelected=writer===\"host_bridge\";\n const valNativeActive=valNativeSelected && mode===\"ACTIVE\";\n const valNativePrepared=valNativeSelected && mode===\"PREPARED\";\n\n const bridgeWorker:any=await sqlite.execute(`\n SELECT worker_id,instance_id,last_poll_at,last_result_at,\n (julianday('now')-julianday(last_poll_at))*86400.0 AS poll_age_seconds\n FROM brain_bridge_workers_v4\n ORDER BY last_poll_at DESC LIMIT 1`);\n const bw:any=bridgeWorker.rows?.[0]||null;\n const bridgeQueue:any=await sqlite.execute(`SELECT\n SUM(CASE WHEN state='READY' THEN 1 ELSE 0 END) AS ready_count,\n SUM(CASE WHEN state='LEASED' AND julianday(lease_expires_at) IS NOT NULL AND julianday(lease_expires_at) > julianday('now') THEN 1 ELSE 0 END) AS active_lease_count,\n SUM(CASE WHEN state='LEASED' AND (julianday(lease_expires_at) IS NULL OR julianday(lease_expires_at) <= julianday('now')) THEN 1 ELSE 0 END) AS expired_lease_count\n FROM brain_bridge_jobs`);\n const bq:any=bridgeQueue.rows?.[0]||{};\n const bridgeAge=bw&&bw.poll_age_seconds!==null&&bw.poll_age_seconds!==undefined?Number(bw.poll_age_seconds):null;\n const bridgeState=bridgeAge===null||!Number.isFinite(bridgeAge)||bridgeAge<0?\"UNKNOWN\":bridgeAge<=90?\"HEALTHY\":bridgeAge<=180?\"DEGRADED\":\"DOWN\";\n const transportClean=Number(bq.expired_lease_count||0)===0;\n const legacyBridgeUsable=hostBridgeSelected && bridgeState===\"HEALTHY\" && transportClean;\n\n let vt:any=null;\n try{\n const vr:any=await sqlite.execute(`\n SELECT id,worker_id,instance_id,authority_epoch,state,tick_at,expires_at,\n (julianday('now')-julianday(tick_at))*86400.0 AS tick_age_seconds,\n CASE WHEN julianday(expires_at) IS NOT NULL AND julianday(expires_at) > julianday('now') THEN 1 ELSE 0 END AS expiry_fresh\n FROM val_native_executor_runtime_v1\n WHERE id='val-native-executor'\n LIMIT 1`);\n vt=vr.rows?.[0]||null;\n }catch{}\n const valNativeTickAge=vt&&vt.tick_age_seconds!==null&&vt.tick_age_seconds!==undefined?Number(vt.tick_age_seconds):null;\n const valNativeTickFresh=!!vt\n && String(vt.state)===\"RUNNING\"\n && Number(vt.authority_epoch)===Number(auth?.epoch)\n && Number(vt.expiry_fresh)===1\n && valNativeTickAge!==null\n && Number.isFinite(valNativeTickAge)\n && valNativeTickAge>=0\n && valNativeTickAge<=300;\n const valNativeReadUsable=(valNativeActive||valNativePrepared)&&valNativeTickFresh&&transportClean;\n const valNativeMutationUsable=valNativeActive&&valNativeTickFresh&&transportClean;\n const canonicalMutationUsable=valNativeMutationUsable || (hostBridgeSelected&&mode===\"ACTIVE\"&&legacyBridgeUsable);\n const canonicalReadUsable=valNativeReadUsable || (hostBridgeSelected&&[\"ACTIVE\",\"PREPARED\"].includes(mode)&&legacyBridgeUsable);\n const controlPlaneState=valNativeSelected\n ?(!transportClean?\"VAL_NATIVE_EXPIRED_TRANSPORT_LEASE\":!valNativeTickFresh?\"VAL_NATIVE_RUNTIME_STALE\":valNativeActive?\"VAL_NATIVE_ACTIVE\":\"VAL_NATIVE_PREPARED\")\n :hostBridgeSelected\n ?(legacyBridgeUsable?(mode===\"ACTIVE\"?\"LEGACY_BRIDGE_ACTIVE\":\"LEGACY_BRIDGE_PREPARED\"):\"LEGACY_BRIDGE_UNAVAILABLE\")\n :\"CONTROL_PLANE_UNKNOWN_WRITER\";\n for(const s of SUBSTRATES){\n await sqlite.execute({sql:\"INSERT INTO agent_fabric_substrates(id,state,hard_zero_spend,max_known_slots,control,evidence,updated_at) VALUES(?,?,?,?,?,?,?) ON CONFLICT(id) DO UPDATE SET state=excluded.state,hard_zero_spend=excluded.hard_zero_spend,max_known_slots=excluded.max_known_slots,control=excluded.control,evidence=excluded.evidence,updated_at=excluded.updated_at\",\n args:[s.id,s.state,s.hard_zero_spend?1:0,s.max_known_slots,s.control,s.evidence,nowIso]});\n }\n\n const snap=await latestSnapshot();\n if(!snap&&!canonicalReadUsable)return {ok:false,error:\"NO_SNAPSHOT_AND_NO_CANONICAL_READ\"};\n const snapState:any=snap?.doc?.snapshot||{};\n let decisionSource=\"DURABLE_SNAPSHOT_DIAGNOSTIC_ONLY\";\n let decisionGeneration=Number(snapState.generation);\n let tasks:any[]=snapState.tasks||[],agents:any[]=snapState.agents||[],claims:any[]=snapState.claims||[],artifacts:any[]=snapState.artifacts||[];\n if(canonicalReadUsable){\n try{\n const live=await readCanonicalDecisionState();\n decisionSource=\"LIVE_CANONICAL\";decisionGeneration=live.generation;\n tasks=live.tasks;agents=live.agents;claims=live.claims;artifacts=live.artifacts;\n }catch(e){\n return {\n ok:false,\n error:\"LIVE_CANONICAL_DECISION_READ_FAILED_FAIL_CLOSED\",\n detail:e instanceof Error?e.message:String(e),\n decision_state_source:\"UNAVAILABLE\",\n diagnostic_snapshot_generation:Number(snap?.meta?.generation??snapState.generation??-1),\n diagnostic_snapshot_key:snap?.key??null,\n population_ticket_mutation_performed:false\n };\n }\n }\n if(!Number.isInteger(decisionGeneration))return {ok:false,error:\"DECISION_GENERATION_MISSING\"};\n const nowMs=now.getTime();\n const recent=recentAgents(agents,nowMs);\n const hbRes:any=await sqlite.execute({sql:\"SELECT instance_id,provider_id,brain_agent_id,workstream,capabilities_json,state,heartbeat_at,expires_at FROM agent_fabric_execution_heartbeats WHERE state='RUNNING' AND julianday(expires_at) IS NOT NULL AND julianday(expires_at) > julianday('now') ORDER BY julianday(heartbeat_at) DESC,heartbeat_at DESC\"});\n const freshHeartbeats:any[]=hbRes.rows||[];\n const freshBrainIds=new Set(freshHeartbeats.map((h:any)=>String(h.brain_agent_id||\"\")).filter(Boolean));\n const recentIds=new Set(recent.map(a=>String(a.id)));\n const heartbeatCoveredRecent=[...freshBrainIds].filter(id=>recentIds.has(id)).length;\n const heartbeatCoverage=recent.length?heartbeatCoveredRecent/recent.length:0;\n const heartbeatRolloutReady=heartbeatCoverage>=0.8&&freshHeartbeats.length>=2;\n const attestedAgents=recent.filter(a=>freshBrainIds.has(String(a.id)));\n const leased=tasks.filter(t=>String(t.state)===\"LEASED\");\n const leasedOwners=new Set(leased.map(t=>String(t.lease_owner||\"\")).filter(Boolean));\n const idleAttested=attestedAgents.filter(a=>!leasedOwners.has(String(a.id)));\n const frontier=parallelFrontier(tasks,claims,artifacts,agents);\n const legacyCapabilityBlocked=frontier.filter(t=>REQ(t).includes(\"sprite_exec\"));\n const assignedFrontier=frontier.filter(t=>t.assigned_agent!==null&&t.assigned_agent!==undefined);\n const genericFrontier=frontier.filter(t=>t.assigned_agent===null||t.assigned_agent===undefined).filter(t=>!REQ(t).includes(\"sprite_exec\"));\n const matching=maximumIdleMatching(genericFrontier,idleAttested);\n const unmatched=genericFrontier.filter(t=>!matching.taskToAgent.has(String(t.id)));\n const provisionableUnmatched=unmatched;\n const provisionableStructural=genericFrontier;\n const supplyAgents=canonicalMutationUsable?attestedAgents:[];\n const idle=canonicalMutationUsable?idleAttested:[];\n const idleRows=idle.map(a=>({agent:a,matches:genericFrontier.filter(t=>agentMatches(t,a))}));\n const matchedIdleIds=new Set([...matching.agentToTask.keys()]);\n const idleMatchable=idleRows.filter(x=>x.matches.length>0);\n const idleBlocked=idleRows.filter(x=>!matchedIdleIds.has(String(x.agent.id)));\n const nominalSupplyAgents=recent;\n\n const populationMutationAllowed=canonicalMutationUsable&&decisionSource===\"LIVE_CANONICAL\";\n const extraNeeded=populationMutationAllowed?provisionableUnmatched.length:0;\n let open:any;\n const ticketTx:any=await (sqlite as any).transaction(\"write\");\n let ticketTxDone=false;\n try{\n if(canonicalMutationUsable){\n if(decisionSource!==\"LIVE_CANONICAL\"){\n await ticketTx.rollback();ticketTxDone=true;\n return {ok:false,error:\"POPULATION_DECISION_SOURCE_NOT_LIVE_FAIL_CLOSED\",decision_state_source:decisionSource,decision_generation:decisionGeneration,population_ticket_mutation_performed:false};\n }\n const g:any=await ticketTx.execute(\"SELECT generation FROM brainvn_epoch_meta WHERE id=1\");\n const currentGeneration=Number(g.rows?.[0]?.generation);\n if(!Number.isInteger(currentGeneration)||currentGeneration!==decisionGeneration){\n await ticketTx.rollback();ticketTxDone=true;\n return {ok:false,error:\"CAPACITY_DECISION_GENERATION_CHANGED_RECOMPUTE_REQUIRED\",decision_generation:decisionGeneration,current_generation:Number.isInteger(currentGeneration)?currentGeneration:null,population_ticket_mutation_performed:false};\n }\n }\n await ticketTx.execute({sql:\"UPDATE agent_fabric_tickets SET state='STALE',updated_at=? WHERE state='OPEN'\",args:[nowIso]});\n\n if(!canonicalMutationUsable){\n const prepared=valNativePrepared;\n await ticketTx.execute({sql:\"INSERT INTO agent_fabric_tickets(id,kind,workstream,task_id,required_caps_json,desired_instances,priority,state,reason,created_at,updated_at) VALUES(?,?,?,?,?,?,?,?,?,?,?) ON CONFLICT(id) DO UPDATE SET kind=excluded.kind,required_caps_json=excluded.required_caps_json,desired_instances=excluded.desired_instances,priority=excluded.priority,state='OPEN',reason=excluded.reason,updated_at=excluded.updated_at\",\n args:[\n prepared?\"CONTROL_PLANE_PREPARED_FENCE\":\"CONTROL_PLANE_LIVENESS_DEFICIT\",\n prepared?\"CREATE_INDEPENDENT_USEFUL_WORK\":\"PROVISION_MORE\",\n \"global\",null,\n JSON.stringify([prepared?\"brain_control_plane_prepared_review\":\"brain_control_plane_liveness\"]),\n 1,1000000000,\"OPEN\",\n prepared\n ?`Val-native authority epoch ${Number(auth?.epoch||0)} is PREPARED. Canonical mutations are intentionally fenced; do not revive the legacy bridge or provision UI chats. Keep internal nonauthority cells active and prioritize the atomicity/read-lane repair needed for ACTIVE promotion.`\n :`No usable canonical writer. Legacy bridge state=${bridgeState}; worker age=${bridgeAge}; ready_jobs=${Number(bq.ready_count||0)}. Restore or replace the execution control plane before counting Brain-facing identities as usable capacity.`,\n nowIso,nowIso\n ]});\n }\n\n for(const t of unmatched){\n const req=REQ(t);\n const legacySprite=req.includes(\"sprite_exec\");\n // Capability migration remains useful while canonical mutations are fenced because it removes\n // obsolete task contracts. Ordinary SPAWN_COMPATIBLE demand waits until the selected writer can\n // claim/commit; internal nonauthority cells may still attack the underlying decision tickets.\n if(!canonicalMutationUsable && !legacySprite)continue;\n const id=(legacySprite?\"MIGRATE_CAPABILITY:\":\"SPAWN_FOR_TASK:\")+String(t.id);\n const kind=legacySprite?\"MIGRATE_OR_REBIND_CAPABILITY\":\"SPAWN_COMPATIBLE\";\n const reason=legacySprite\n ?\"Task requires legacy sprite_exec, which is maintenance-only under the current Val-first transport law; migrate/rebind the task instead of spawning routine Sprite workers\"\n :\"Structurally ready task has no compatible recent agent\";\n await ticketTx.execute({sql:\"INSERT INTO agent_fabric_tickets(id,kind,workstream,task_id,required_caps_json,desired_instances,priority,state,reason,created_at,updated_at) VALUES(?,?,?,?,?,?,?,?,?,?,?) ON CONFLICT(id) DO UPDATE SET kind=excluded.kind,required_caps_json=excluded.required_caps_json,desired_instances=excluded.desired_instances,priority=excluded.priority,state='OPEN',reason=excluded.reason,updated_at=excluded.updated_at\",\n args:[id,kind,String(t.workstream),String(t.id),JSON.stringify(req),1,Number(t.priority)||0,\"OPEN\",reason,nowIso,nowIso]});\n }\n\n if(idleBlocked.length){\n const byWs=new Map();\n for(const x of idleBlocked){const ws=String(x.agent.workstream);byWs.set(ws,(byWs.get(ws)||0)+1);}\n for(const [ws,n] of byWs){\n await ticketTx.execute({sql:\"INSERT INTO agent_fabric_tickets(id,kind,workstream,task_id,required_caps_json,desired_instances,priority,state,reason,created_at,updated_at) VALUES(?,?,?,?,?,?,?,?,?,?,?) ON CONFLICT(id) DO UPDATE SET desired_instances=excluded.desired_instances,state='OPEN',reason=excluded.reason,updated_at=excluded.updated_at\",\n args:[\"SURPLUS_WORK:\"+ws,\"CREATE_INDEPENDENT_USEFUL_WORK\",ws,null,\"[]\",n,1000000000,\"OPEN\",\"Live agents exist with no matching direct task; work factory should expose independent falsification/discovery/verification work\",nowIso,nowIso]});\n }\n }\n\n const lowerBoundUsefulDemand=provisionableStructural.length;\n // Do not provision ordinary canonical workers while the selected writer cannot mutate.\n // PREPARED mode keeps internal nonauthority cells running instead of creating UI-spawn pressure.\n if(populationMutationAllowed && extraNeeded){\n await ticketTx.execute({sql:\"INSERT INTO agent_fabric_tickets(id,kind,workstream,task_id,required_caps_json,desired_instances,priority,state,reason,created_at,updated_at) VALUES(?,?,?,?,?,?,?,?,?,?,?) ON CONFLICT(id) DO UPDATE SET desired_instances=excluded.desired_instances,state='OPEN',reason=excluded.reason,updated_at=excluded.updated_at\",\n args:[\"GLOBAL_CAPACITY_DEFICIT\",\"PROVISION_MORE\",null,null,\"[]\",extraNeeded,1000000000,\"OPEN\",\"Known useful demand exceeds recent live agent supply; provision additional legitimate zero-spend workers\",nowIso,nowIso]});\n }\n\n open=await ticketTx.execute({sql:\"SELECT id,kind,workstream,task_id,required_caps_json,desired_instances,priority,reason FROM agent_fabric_tickets WHERE state='OPEN' ORDER BY priority DESC,id\"});\n await ticketTx.commit();ticketTxDone=true;\n }catch(e){\n if(!ticketTxDone){try{await ticketTx.rollback()}catch{}}\n throw e;\n }\n const state={\n schema:\"PROJECT_BRAIN_AGENT_FABRIC_STATE_V2\",\n sampled_at:nowIso,snapshot_generation:decisionGeneration,snapshot_key:decisionSource===\"LIVE_CANONICAL\"?null:(snap?.key??null),\n policy:\"MAXIMUM_USEFUL_AGENT_CAPACITY\",\n invariants:[\n \"configured providers do not count as capacity until real execution is proven\",\n \"agent identity is disposable; task/evidence state survives it\",\n \"no provider bypasses Brain lease/claim/commit fencing\",\n \"zero-out-of-pocket providers only unless economic constraint changes\",\n \"surplus agents are redirected to independent useful work instead of being discarded\"\n ],\n observed:{\n decision_state_source:decisionSource,\n decision_generation:decisionGeneration,\n diagnostic_snapshot_generation:Number(snap?.meta?.generation??snapState.generation??-1),\n diagnostic_snapshot_key:snap?.key??null,\n recent_agent_identities_15m:recent.length,\n nominal_recent_agent_supply:nominalSupplyAgents.length,\n control_plane_state:controlPlaneState,\n control_plane_epoch:auth?Number(auth.epoch):null,\n control_plane_writer:auth?.writer??null,\n control_plane_mode:auth?.mode??null,\n control_plane_source_generation:auth?Number(auth.source_generation):null,\n control_plane_liveness_source:valNativeSelected?\"val_native_runtime_tick\":hostBridgeSelected?\"host_bridge_worker\":\"unknown\",\n val_native_runtime_tick_state:vt?.state??null,\n val_native_runtime_tick_epoch:vt?Number(vt.authority_epoch):null,\n val_native_runtime_tick_at:vt?.tick_at??null,\n val_native_runtime_tick_expires_at:vt?.expires_at??null,\n val_native_runtime_tick_age_seconds:valNativeTickAge,\n val_native_runtime_tick_fresh:valNativeTickFresh,\n canonical_read_usable:canonicalReadUsable,\n canonical_mutation_usable:canonicalMutationUsable,\n legacy_bridge_worker_state:bridgeState,\n legacy_bridge_worker_poll_age_seconds:bridgeAge,\n legacy_bridge_ready_jobs:Number(bq.ready_count||0),\n legacy_bridge_active_transport_leases:Number(bq.active_lease_count||0),\n legacy_bridge_expired_transport_leases:Number(bq.expired_lease_count||0),\n attested_live_execution_incarnations:freshHeartbeats.length,\n heartbeat_covered_recent_identities:heartbeatCoveredRecent,\n heartbeat_adoption_ratio:Number(heartbeatCoverage.toFixed(4)),\n supply_metric_mode:heartbeatRolloutReady?\"ATTESTED_EXECUTIONS\":\"ATTESTED_ONLY_FAIL_SAFE_DURING_HEARTBEAT_ROLLOUT\",\n effective_supply_agents:supplyAgents.length,\n attested_supply_agents:attestedAgents.length,\n idle_attested_supply_agents:idleAttested.length,\n parallel_frontier_tasks:frontier.length,\n generic_parallel_frontier_tasks:genericFrontier.length,\n assigned_parallel_frontier_tasks:assignedFrontier.length,\n matched_idle_attested_agents:matching.matched,\n capacity_deficit_instances:extraNeeded,\n leased_effective_supply_agents:supplyAgents.filter(a=>leasedOwners.has(String(a.id))).length,\n idle_effective_supply_agents:idle.length,\n structurally_claimable_tasks:frontier.length,\n direct_matchable_tasks:genericFrontier.length-provisionableUnmatched.length,\n unmatched_claimable_tasks:unmatched.length,\n provisionable_unmatched_tasks:provisionableUnmatched.length,\n legacy_capability_migration_tasks:legacyCapabilityBlocked.length,\n idle_matchable_agents:idleMatchable.length,\n idle_blocked_agents:idleBlocked.length\n },\n substrate_registry:SUBSTRATES,\n open_tickets:open.rows||[],\n state:valNativePrepared?\"CONTROL_PLANE_PREPARED_NONAUTHORITY_CELLS_ACTIVE\":!canonicalMutationUsable?\"CONTROL_PLANE_UNAVAILABLE\":provisionableUnmatched.length>0?\"NEEDS_COMPATIBLE_CAPACITY\":legacyCapabilityBlocked.length>0?\"NEEDS_LEGACY_CAPABILITY_MIGRATION\":idleBlocked.length>0?\"NEEDS_SURPLUS_WORK_DIVERSIFICATION\":provisionableStructural.length>supplyAgents.length?\"NEEDS_MORE_CAPACITY\":\"CURRENT_LIVE_CAPACITY_HAS_WORK\"\n };\n await blob.set(\"capacity/agent_fabric_latest_v2.json\",JSON.stringify(state,null,2));\n await sqlite.execute({sql:\"INSERT OR REPLACE INTO agent_fabric_samples(sampled_at,snapshot_generation,snapshot_key,recent_agents_15m,leased_recent_agents,idle_recent_agents,structurally_claimable_tasks,direct_matchable_tasks,unmatched_claimable_tasks,idle_matchable_agents,idle_blocked_agents,open_capacity_tickets,state_json) VALUES(?,?,?,?,?,?,?,?,?,?,?,?,?)\",\n args:[nowIso,decisionGeneration,decisionSource===\"LIVE_CANONICAL\"?null:(snap?.key??null),recent.length,supplyAgents.filter(a=>leasedOwners.has(String(a.id))).length,idle.length,frontier.length,genericFrontier.length-provisionableUnmatched.length,provisionableUnmatched.length,idleMatchable.length,idleBlocked.length,(open.rows||[]).length,JSON.stringify(state)]});\n console.log(JSON.stringify(state));\n return state;\n}",[58],{"_34":57,"_13":58,"_37":59,"_39":-5,"_40":41,"_42":60,"_44":45,"_46":71,"_17":62,"_49":50,"_51":63,"_53":54,"_55":-5,"_68":72,"_18":73},{"_34":35,"_13":36,"_37":38,"_39":-5,"_40":41,"_42":43,"_44":45,"_46":67,"_17":48,"_49":50,"_51":52,"_53":54,"_55":-5,"_68":69,"_18":70},["D",1788806136933],"children",[],[36],["D",1788806135046],[],[58],"1eaca24b-dcf3-457b-a01d-3263c9740fcb",["D",1788805545328],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","Temporary compile-only V5R2","imageUrl","userId","6be0fc5c-1fef-4bd6-a1e1-67a3f8c0764e","pinnedFileId","pinPreview","pinMigrated","screenshotVersion","likeCount",0,"orgId","01a0715b-703f-741f-ab35-c85020e4a5e0","tursoName","1eaca24bdcf3457ba01d3263c9740fcb","tursoHostname","1eaca24bdcf3457ba01d3263c9740fcb-val-town.aws-us-east-2.turso.io","tursoMeasuredAt",["D",1789501263826],"pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_11":12,"_132":128},"org",{"_11":12,"_125":126,"_127":128,"_84":85,"_129":130,"_131":54},"branch",{"_17":43,"_13":16,"_34":41,"_117":74,"_118":-5,"_119":-5,"_120":-5,"_121":-5,"_122":-5,"_123":14,"_124":12},"isOwned","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","adoptOrgId",{"_34":74,"_13":14,"_46":170,"_76":-5,"_77":54,"_78":79,"_80":79,"_81":82,"_83":-5,"_84":85,"_86":-5,"_87":54,"_88":-5,"_89":-5,"_90":91,"_92":93,"_94":95,"_96":97,"_98":171,"_100":-5,"_101":102,"_103":102,"_104":105,"_106":105,"_107":105,"_108":102,"_109":102,"_110":172,"_112":173,"_114":174,"_116":54},[164,165],"files",[164,165],"counts",{"_155":91,"_156":48,"_157":91,"_31":158,"_159":160},[151,152],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},{"_34":57,"_13":58,"_37":59,"_39":-5,"_40":41,"_42":60,"_44":45,"_46":61,"_17":62,"_49":50,"_51":63,"_53":54,"_55":-5,"_18":154},{"_34":35,"_13":36,"_37":38,"_39":-5,"_40":41,"_42":43,"_44":45,"_46":47,"_17":48,"_49":50,"_51":52,"_53":54,"_55":-5,"_18":153},[36],[58],"pulls","branches","forks",{"_161":91,"_163":91},"connections",{"_161":91,"_162":91},"count","unfilledCount","emptyCount",{"_34":57,"_13":58,"_37":59,"_39":-5,"_40":41,"_42":60,"_44":45,"_46":71,"_17":62,"_49":50,"_51":63,"_53":54,"_55":-5,"_68":168,"_18":169},{"_34":35,"_13":36,"_37":38,"_39":-5,"_40":41,"_42":43,"_44":45,"_46":67,"_17":48,"_49":50,"_51":52,"_53":54,"_55":-5,"_68":166,"_18":167},[],[36],[],[58],["D",1788805545328],["D",1789501263826],{"_11":12,"_132":128},{"_11":12,"_125":126,"_127":128,"_84":85,"_129":130,"_131":54},{"_17":43,"_13":16,"_34":41,"_117":74,"_118":-5,"_119":-5,"_120":-5,"_121":-5,"_122":-5,"_123":14,"_124":12},"ctx",{"_110":-5,"_148":208,"_209":210,"_211":212,"_213":54,"_214":54,"_215":54,"_216":45,"_217":-5,"_218":-7,"_219":-7,"_220":91,"_221":54,"_222":54,"_223":-5,"_224":54,"_225":54,"_226":54,"_227":-5},"ENV",{"_179":180,"_181":182,"_183":16,"_184":185,"_186":187,"_188":189,"_190":191,"_192":193,"_194":195,"_196":197,"_198":199,"_200":201,"_202":203,"_204":205,"_206":207},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","RENDER_GIT_COMMIT","e87eb04e707cf64e7e532c8e8ec395f209e17f15","RENDER_GIT_BRANCH","POSTHOG_API_TOKEN","phc_nmoyuAkStEZuUp69rYlg1DZgrIt19Gx0Y4Hwf8tGgJP","POSTHOG_API_HOST","https://wart.val.town","WEB_API_TEMPLATE","https://{val}.web.val.run","APP_URL","https://www.val.town","MODULE_URL","https://esm.town","VANITY_WEB_API_TEMPLATE","https://{label}.val.run/","DENOLS_URL","https://lsp.val.town","NODE_ENV","production","CLOUDFLARE_TURNSTILE_SITE_KEY","0x4AAAAAACtaIZJH7s9rBMZ6","GOOGLE_CLIENT_ID","875989696899-jtsqkhlbdv5jrlsk8631p7ipjg3c6o62.apps.googleusercontent.com","STRIPE_PUBLISHABLE_KEY","pk_live_51N2zvWEpZTTLipIkVEwXrUG9AT0yeOOEYxszarZT1jpsZV58Ly6wlg3SltZpHN26CUalOBmUSY7adQRQiSkCZz2500qSXNkf8Y","API_URL","https://api.val.town",[],"preferencesKeybindings","default","preferencesTheme","light","preferencesFixers","preferencesCopilot","preferencesSelectionAi","preferencesCloseBrackets","preferencesChatPanelState","preferencesDprint","preferencesDenofmt","notificationCount","flagDenols","isBusinessOrgMember","businessOrgHandle","isBusinessOrgAdmin","isHigherTownieTier","navCollapsed","currentOrgId"]

Code