[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_169":170,"_171":172},"routes/_app.x.$handle.$name",{"_98":97,"_32":45,"_107":88,"_27":108,"_13":14,"_109":-5,"_11":110,"_111":112,"_113":114,"_115":116,"_117":118,"_20":-5,"_119":-5,"_120":-5,"_121":25,"_122":123,"_124":25,"_125":-5,"_126":-5,"_127":128},"routes/_app.x.$handle.$name.branch.$branch.version.$version.diff",{"_11":12,"_13":14,"_15":16,"_17":-5,"_18":-5},"project",{"_43":44,"_32":45,"_38":46,"_47":-5,"_48":25,"_49":50,"_51":50,"_52":53,"_54":-5,"_18":55,"_56":-5,"_57":25,"_58":-5,"_59":-5,"_60":61,"_62":63,"_64":65,"_66":67,"_68":69,"_70":-5,"_71":72,"_73":72,"_74":75,"_76":75,"_77":75,"_78":72,"_79":72,"_80":81,"_82":83,"_84":85,"_86":25},"version",8,"changes",[19],"aiChatInfo","userId",{"_20":21,"_22":23,"_24":25,"_26":25,"_27":28,"_29":28},"file",{"_30":31,"_32":28,"_33":34,"_35":37,"_38":39,"_40":14,"_41":42,"_24":25},"previous",{"_30":31,"_32":28,"_33":34,"_35":36},"deleted",false,"deletedHere","path","candidate.ts","latestPath","fileId","c48c5a9a-aae9-11f1-aa1e-1607ee4eb77e","name","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 CAST((julianday('now')-julianday(last_poll_at))*86400 AS INTEGER) 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 CAST((julianday('now')-julianday(tick_at))*86400 AS INTEGER) 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 idleMatchable=idleRows.filter(x=>x.matches.length>0);\n const idleBlocked=idleRows.filter(x=>x.matches.length===0);\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 x of unmatched){\n const t=x.task,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}","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 CAST((julianday('now')-julianday(last_poll_at))*86400 AS INTEGER) 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 CAST((julianday('now')-julianday(tick_at))*86400 AS INTEGER) 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 idleMatchable=idleRows.filter(x=>x.matches.length>0);\n const idleBlocked=idleRows.filter(x=>x.matches.length===0);\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}","createdAt",["D",1788805813748],"branchVersion","branchId","c32bed25-9a9d-40ba-bc65-f61c6e0cea31","id","1eaca24b-dcf3-457b-a01d-3263c9740fcb","capacity-v5r2-compile-2012",["D",1788805545328],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","Temporary compile-only V5R2","imageUrl","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",{"_98":97,"_106":102},"org",{"_98":97,"_99":100,"_101":102,"_18":55,"_103":104,"_105":25},"branch",{"_13":87,"_32":88,"_43":42,"_89":44,"_90":-5,"_91":-5,"_92":-5,"_93":-5,"_94":-5,"_95":45,"_96":97},"isOwned",10,"main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","mosadek","handle","displayName","Mo Sadek","avatar","https://lh3.googleusercontent.com/a/ACg8ocL1eT_LHhKSg5px3nXIO6eez79aZXef466qXKh2gak-0iwrvw=s96-c","tier","free","canRestrictVals","profileImageUrl","branchName","","adoptOrgId",{"_43":44,"_32":45,"_38":164,"_47":-5,"_48":25,"_49":50,"_51":50,"_52":53,"_54":-5,"_18":55,"_56":-5,"_57":25,"_58":-5,"_59":-5,"_60":61,"_62":63,"_64":65,"_66":67,"_68":165,"_70":-5,"_71":72,"_73":72,"_74":75,"_76":75,"_77":75,"_78":72,"_79":72,"_80":166,"_82":167,"_84":168,"_86":25},"tree",[155,156],"files",[155,156],"counts",{"_145":61,"_146":143,"_147":61,"_148":149,"_150":151},"contents",[129,130],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},{"_43":141,"_32":28,"_30":31,"_134":-5,"_41":42,"_40":14,"_136":25,"_38":142,"_13":143,"_33":34,"_35":37,"_24":25,"_139":-5,"_27":144},{"_43":131,"_32":132,"_30":133,"_134":-5,"_41":42,"_40":135,"_136":25,"_38":137,"_13":61,"_33":34,"_35":138,"_24":25,"_139":-5,"_27":140},"d06f8959-bb7f-4b95-b0ec-f8fb636f164f","runtime_regression.ts","ebec773c-aae9-11f1-ad8f-1607ee4eb77e","parentId",7,"latest",["D",1788805708723],"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\";\n\nconst tableNames=[\n \"agent_fabric_samples\",\"agent_fabric_tickets\",\"agent_fabric_substrates\",\"agent_fabric_execution_heartbeats\",\n \"brain_control_plane_authority_v1\",\"brain_bridge_workers_v4\",\"brain_bridge_jobs\",\"val_native_executor_runtime_v1\",\n \"brainvn_epoch_meta\",\"brainvn_tasks\",\"brainvn_agents\",\"brainvn_claims\",\"brainvn_artifacts\"\n];\nasync function reset({claims=true}={claims:true}){\n for(const t of tableNames) 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 now=new Date(), exp=new Date(now.getTime()+10*60_000);\n await sqlite.execute({sql:\"INSERT INTO brain_control_plane_authority_v1 VALUES(1,2,'val_native',0,'head','ACTIVE',?,?)\",args:[now.toISOString(),now.toISOString()]});\n await sqlite.execute({sql:\"INSERT INTO val_native_executor_runtime_v1 VALUES('val-native-executor','w','i',2,'RUNNING',?,?)\",args:[now.toISOString(),exp.toISOString()]});\n await sqlite.execute({sql:\"INSERT INTO brainvn_epoch_meta VALUES(1,100)\",args:[]});\n}\nasync function setGen(g:number){await sqlite.execute({sql:\"UPDATE brainvn_epoch_meta SET generation=? WHERE id=1\",args:[g]})}\nasync function addTask(id:string,patch:any={}){\n const t={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,...patch};\n await sqlite.execute({sql:\"INSERT INTO brainvn_tasks(id,workstream,state,priority,dedupe_key,context_manifest,requires_json,depends_json,guards_json,writes_json,assigned_agent,lease_owner) VALUES(?,?,?,?,?,?,?,?,?,?,?,?)\",\n args:[id,t.workstream,t.state,t.priority,t.dedupe_key,t.context_manifest,t.requires_json,t.depends_json,t.guards_json,t.writes_json,t.assigned_agent,t.lease_owner]});\n}\nasync function addAgent(id:string,caps:string[]=[\"alpha\"]){\n const now=new Date();\n await sqlite.execute({sql:\"INSERT INTO brainvn_agents VALUES(?,?,?,?)\",args:[id,\"global\",now.toISOString(),JSON.stringify(caps)]});\n}\nasync function addHb(agent:string,caps:string[]=[\"alpha\"]){\n const now=new Date(),exp=new Date(now.getTime()+10*60_000);\n await sqlite.execute({sql:\"INSERT INTO agent_fabric_execution_heartbeats VALUES(?,?,?,?,?,'RUNNING',?,?,?,?)\",\n args:[\"hb:\"+agent,\"test\",agent,\"global\",JSON.stringify(caps),now.toISOString(),now.toISOString(),exp.toISOString(),\"{}\"]});\n}\nasync function createTicketTable(){\n 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)\");\n}\nasync function sentinel(){\n await createTicketTable(); const n=new Date().toISOString();\n await sqlite.execute({sql:\"INSERT INTO agent_fabric_tickets VALUES('SENTINEL','PROVISION_MORE','global',NULL,'[]',9,1,'OPEN','prior-good',?,?)\",args:[n,n]});\n}\nasync function ticketRows(){const r:any=await sqlite.execute(\"SELECT id,state,desired_instances FROM agent_fabric_tickets ORDER BY id\");return r.rows||[]}\nfunction must(cond:any,msg:string){if(!cond)throw new Error(\"ASSERT:\"+msg)}\nconst results:any[]=[];\nasync function test(name:string,fn:()=>Promise){try{await fn();results.push({name,ok:true})}catch(e){results.push({name,ok:false,error:e instanceof Error?e.message:String(e)})}}\n\n// 1. Live canonical must work with no durable snapshot at all.\nawait test(\"live canonical works without snapshot\",async()=>{\n await reset(); await setGen(101); await addTask(\"r1\"); await addTask(\"r2\",{priority:99});\n const out:any=await controller();\n must(out?.observed?.decision_state_source===\"LIVE_CANONICAL\",\"source\");\n must(out?.observed?.decision_generation===101,\"generation\");\n must(out?.observed?.capacity_deficit_instances===2,\"deficit=2\");\n must(out?.snapshot_key===null,\"snapshot null\");\n});\n\n// Add a deliberately stale snapshot only after no-snapshot test.\nawait blob.set(\"snapshots/brain_snapshot_g50_synthetic.json\",JSON.stringify({snapshot:{generation:50,tasks:[],agents:[],claims:[],artifacts:[]}}));\n\n// 2. Live read fault must not touch prior demand or fall back into stale population mutation.\nawait test(\"live read failure preserves tickets and fails closed\",async()=>{\n await reset({claims:false}); await setGen(102); await addTask(\"r1\"); await sentinel();\n const out:any=await controller();\n must(out?.error===\"LIVE_CANONICAL_DECISION_READ_FAILED_FAIL_CLOSED\",\"failclosed error\");\n const rows:any[]=await ticketRows(); const s=rows.find(x=>x.id===\"SENTINEL\");\n must(s?.state===\"OPEN\"&&Number(s?.desired_instances)===9,\"sentinel preserved\");\n});\n\n// 3. Malformed dependency JSON cannot manufacture readiness.\nawait test(\"malformed causal json is rejected\",async()=>{\n await reset(); await setGen(103);\n await addTask(\"good\",{writes_json:'[\"good\"]'});\n await addTask(\"bad\",{priority:200,depends_json:\"[broken\",writes_json:'[\"bad\"]'});\n const out:any=await controller();\n must(out?.observed?.parallel_frontier_tasks===1,\"frontier only good\");\n const ids=(await ticketRows()).map((x:any)=>x.id);\n must(ids.includes(\"SPAWN_FOR_TASK:good\"),\"good spawned\");\n must(!ids.includes(\"SPAWN_FOR_TASK:bad\"),\"bad excluded\");\n});\n\n// 4. Unknown write locks on a leased task abort before ticket mutation.\nawait test(\"malformed leased writes abort without staling prior tickets\",async()=>{\n await reset(); await setGen(104); await sentinel();\n await addTask(\"leased\",{state:\"LEASED\",writes_json:\"[broken\",lease_owner:\"busy\"});\n await addTask(\"ready\",{writes_json:'[\"x\"]'});\n let err=\"\";try{await controller()}catch(e){err=e instanceof Error?e.message:String(e)}\n must(err.includes(\"MALFORMED_LEASED_WRITES:leased\"),\"leased write error\");\n const s=(await ticketRows()).find((x:any)=>x.id===\"SENTINEL\");\n must(s?.state===\"OPEN\",\"sentinel preserved\");\n});\n\n// 5. A busy attested worker must not subtract from additional READY demand.\nawait test(\"busy worker does not suppress ready parallel demand\",async()=>{\n await reset(); await setGen(105);\n await addAgent(\"busy\",[\"alpha\"]); await addHb(\"busy\",[\"alpha\"]);\n await addTask(\"leased\",{state:\"LEASED\",lease_owner:\"busy\",requires_json:'[\"alpha\"]',writes_json:'[\"lease-write\"]'});\n await addTask(\"a\",{requires_json:'[\"alpha\"]',writes_json:'[\"a\"]'});\n await addTask(\"b\",{requires_json:'[\"alpha\"]',writes_json:'[\"b\"]'});\n await addTask(\"c\",{requires_json:'[\"alpha\"]',writes_json:'[\"c\"]'});\n const out:any=await controller();\n must(out?.observed?.attested_supply_agents===1,\"attested=1\");\n must(out?.observed?.leased_effective_supply_agents===1,\"busy leased=1\");\n must(out?.observed?.capacity_deficit_instances===3,\"busy does not subtract\");\n});\n\n// 6. Idle compatible supply uses capability matching.\nawait test(\"idle compatible maximum matching subtracts exactly\",async()=>{\n await reset(); await setGen(106);\n await addAgent(\"idle\",[\"alpha\"]); await addHb(\"idle\",[\"alpha\"]);\n await addTask(\"alpha\",{requires_json:'[\"alpha\"]',writes_json:'[\"a\"]'});\n await addTask(\"beta\",{requires_json:'[\"beta\"]',writes_json:'[\"b\"]'});\n const out:any=await controller();\n must(out?.observed?.matched_idle_attested_agents===1,\"matched=1\");\n must(out?.observed?.capacity_deficit_instances===1,\"deficit=1\");\n});\n\n// 7. Conflicting READY writes are not double-counted.\nawait test(\"ready write conflict yields one simultaneous task\",async()=>{\n await reset(); await setGen(107);\n await addTask(\"hi\",{priority:200,writes_json:'[\"same\"]'});\n await addTask(\"lo\",{priority:100,writes_json:'[\"same\"]'});\n const out:any=await controller();\n must(out?.observed?.parallel_frontier_tasks===1,\"frontier=1\");\n must(out?.observed?.capacity_deficit_instances===1,\"deficit=1\");\n});\n\n// 8. Malformed agent capabilities never count as compatible live supply.\nawait test(\"malformed agent capabilities fail closed\",async()=>{\n await reset(); await setGen(108);\n const now=new Date(),exp=new Date(now.getTime()+10*60_000);\n await sqlite.execute({sql:\"INSERT INTO brainvn_agents VALUES(?,?,?,?)\",args:[\"badagent\",\"global\",now.toISOString(),\"[broken\"]});\n await sqlite.execute({sql:\"INSERT INTO agent_fabric_execution_heartbeats VALUES(?,?,?,?,?,'RUNNING',?,?,?,?)\",args:[\"hb:badagent\",\"test\",\"badagent\",\"global\",'[\"alpha\"]',now.toISOString(),now.toISOString(),exp.toISOString(),\"{}\"]});\n await addTask(\"alpha\",{requires_json:'[\"alpha\"]'});\n const out:any=await controller();\n must(out?.observed?.matched_idle_attested_agents===0,\"malformed agent not matched\");\n must(out?.observed?.capacity_deficit_instances===1,\"deficit remains\");\n});\n\n// 9. Force generation to advance exactly before write transaction; fence must abort with no ticket mutation.\nawait test(\"generation race aborts ticket actuation\",async()=>{\n await reset(); await setGen(109); await sentinel(); await addTask(\"r\",{writes_json:'[\"r\"]'});\n const anySql:any=sqlite as any; const orig=anySql.transaction.bind(anySql); let injected=false;\n try{\n anySql.transaction=async(mode:any)=>{\n if(mode===\"write\"&&!injected){injected=true;await sqlite.execute(\"UPDATE brainvn_epoch_meta SET generation=generation+1 WHERE id=1\")}\n return await orig(mode);\n };\n const out:any=await controller();\n must(out?.error===\"CAPACITY_DECISION_GENERATION_CHANGED_RECOMPUTE_REQUIRED\",\"generation fence error\");\n const s=(await ticketRows()).find((x:any)=>x.id===\"SENTINEL\");\n must(s?.state===\"OPEN\",\"sentinel preserved\");\n }finally{anySql.transaction=orig}\n});\n\nconst failed=results.filter(x=>!x.ok);\nconsole.log(JSON.stringify({ok:failed.length===0,count:results.length,failed:failed.length,results},null,2));\nif(failed.length) throw new Error(\"V5R2_REGRESSION_FAILED:\"+failed.map(x=>x.name).join(\",\"));\n","label",[132],"f49f60a9-0a27-4819-8ab1-75a97477a32a",["D",1788805813748],1,[28],"pulls","branches","forks","envVars",{"_152":61,"_154":61},"connections",{"_152":61,"_153":61},"count","unfilledCount","emptyCount",{"_43":141,"_32":28,"_30":31,"_134":-5,"_41":42,"_40":14,"_136":25,"_38":161,"_13":143,"_33":34,"_35":37,"_24":25,"_139":-5,"_158":162,"_27":163},{"_43":131,"_32":132,"_30":133,"_134":-5,"_41":42,"_40":135,"_136":25,"_38":157,"_13":61,"_33":34,"_35":138,"_24":25,"_139":-5,"_158":159,"_27":160},["D",1788805708723],"children",[],[132],["D",1788805813748],[],[28],["D",1788805545328],["D",1789501263826],{"_98":97,"_106":102},{"_98":97,"_99":100,"_101":102,"_18":55,"_103":104,"_105":25},{"_13":87,"_32":88,"_43":42,"_89":44,"_90":-5,"_91":-5,"_92":-5,"_93":-5,"_94":-5,"_95":45,"_96":97},"ctx",{"_80":-5,"_126":202,"_203":204,"_205":206,"_207":25,"_208":25,"_209":25,"_210":211,"_212":-5,"_213":-7,"_214":-7,"_215":61,"_216":25,"_217":25,"_218":-5,"_219":25,"_220":25,"_221":25,"_222":-5},"ENV",{"_173":174,"_175":176,"_177":88,"_178":179,"_180":181,"_182":183,"_184":185,"_186":187,"_188":189,"_190":191,"_192":193,"_194":195,"_196":197,"_198":199,"_200":201},"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",true,"preferencesChatPanelState","preferencesDprint","preferencesDenofmt","notificationCount","flagDenols","isBusinessOrgMember","businessOrgHandle","isBusinessOrgAdmin","isHigherTownieTier","navCollapsed","currentOrgId"]

Diff · v8