[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8},"actionData","errors","root",{"_106":107,"_108":109},"routes/embed.x.$handle.$name.$",{"_9":10,"_11":12,"_13":14,"_15":16,"_17":18,"_19":20,"_21":-5},"handle","mosadek","name","capacity-v5r2-compile-2012","path","candidate.ts","project",{"_22":45,"_11":12,"_33":46,"_47":-5,"_48":42,"_49":50,"_51":50,"_52":53,"_54":-5,"_55":56,"_57":-5,"_58":42,"_59":-5,"_60":-5,"_61":62,"_63":64,"_65":66,"_67":68,"_69":70,"_71":-5,"_72":73,"_74":73,"_75":76,"_77":76,"_78":76,"_79":73,"_80":73,"_81":82,"_83":84,"_85":86,"_87":42},"file",{"_22":23,"_11":14,"_24":25,"_26":-5,"_27":28,"_29":30,"_31":32,"_33":34,"_35":36,"_37":38,"_39":40,"_41":42,"_43":-5,"_13":44},"permalink","https://www.val.town/x/mosadek/capacity-v5r2-compile-2012/code/candidate.ts","extension","id","fe612124-d701-4a17-8703-f146d9bfa354","fileId","c48c5a9a-aae9-11f1-aa1e-1607ee4eb77e","parentId","branchId","c32bed25-9a9d-40ba-bc65-f61c6e0cea31","branchVersion",9,"latest",true,"createdAt",["D",1788806135046],"version",2,"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\";\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}","deleted",false,"label",[14],"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",{"_9":10,"_105":101},"org",{"_9":10,"_98":99,"_100":101,"_55":56,"_102":103,"_104":42},"branch",{"_35":88,"_11":89,"_22":28,"_90":45,"_91":-5,"_92":-5,"_93":-5,"_94":-5,"_95":-5,"_96":12,"_97":10},"isOwned",10,"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",{"_81":-5,"_139":140,"_141":142,"_143":144,"_145":42,"_146":42,"_147":42,"_148":32,"_149":-5,"_150":-7,"_151":-7,"_152":62,"_153":42,"_154":42,"_155":-5,"_156":42,"_157":42,"_158":42,"_159":-5},"ENV",{"_110":111,"_112":113,"_114":89,"_115":116,"_117":118,"_119":120,"_121":122,"_123":124,"_125":126,"_127":128,"_129":130,"_131":132,"_133":134,"_135":136,"_137":138},"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"]