[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8},"actionData","errors","root",{"_109":110,"_111":112},"routes/embed.x.$handle.$name.$",{"_9":10,"_11":12,"_13":14,"_15":16,"_17":18,"_19":20,"_21":-5},"handle","mosadek","name","r3a3-m6q9-shadow2","path","capacity/x71_hash_live_fabric_sources.ts","project",{"_22":48,"_11":12,"_35":49,"_50":-5,"_51":44,"_52":53,"_54":53,"_55":56,"_57":-5,"_58":59,"_60":61,"_62":34,"_63":-5,"_64":-5,"_65":38,"_66":67,"_68":69,"_70":71,"_72":73,"_74":-5,"_75":76,"_77":76,"_78":79,"_80":79,"_81":79,"_82":76,"_83":76,"_84":85,"_86":87,"_88":89,"_90":44},"file",{"_22":23,"_11":24,"_25":26,"_27":28,"_29":30,"_31":32,"_33":34,"_35":36,"_37":38,"_39":40,"_41":42,"_43":44,"_45":-5,"_13":46},"permalink","https://www.val.town/x/mosadek/r3a3-m6q9-shadow2/code/capacity/x71_hash_live_fabric_sources.ts","extension","id","f28e5e4e-c291-47f4-817f-b3d4e628191f","x71_hash_live_fabric_sources.ts","fileId","01a092e7-153a-764e-9cee-88e6c2b669d2","parentId","01a092e7-153a-764e-9cee-8e1fd2bf1108","branchId","1da4df5d-ade5-4da9-8efa-00b2d8f1294a","branchVersion",1,"latest",true,"createdAt",["D",1789171012789],"version",0,"fileType","script","content","const docs={\"capacity/capacity_controller.ts\":\"import { sqlite } from \\\"https://esm.town/v/std/sqlite/main.ts\\\";\\nimport { blob } from \\\"https://esm.town/v/std/blob/main.ts\\\";\\n\\nconst J=(s:any,d:any=[])=>{try{return typeof s===\\\"string\\\"?JSON.parse(s):s??d}catch{return d}};\\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:\\\"manual_chat\\\",state:\\\"PROVEN_EPHEMERAL_FALLBACK\\\",hard_zero_spend:true,max_known_slots:null,control:\\\"human_opened\\\",evidence:\\\"real capacity but provisioning is the manual bottleneck to eliminate\\\"}\\n];\\n\\nasync function latestSnapshot(){\\n const xs:any[]=await blob.list(\\\"snapshots/brain_snapshot_g\\\");\\n const gen=(k:string)=>Number(k.match(/^snapshots\\\\/brain_snapshot_g(\\\\d+)_/)?.[1]||-1);\\n xs.sort((a,b)=>gen(b.key)-gen(a.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};\\n}\\n\\nfunction structuralReasons(t:any,byTask:Map,leasedWrites:Set){\\n const r:string[]=[];\\n if(String(t.state)!==\\\"READY\\\")r.push(\\\"NOT_READY\\\");\\n if(J(t.context_manifest,{}).execution_allowed===false)r.push(\\\"EXECUTION_DISALLOWED\\\");\\n for(const d of J(t.depends_json,[])){\\n const x=byTask.get(String(d));\\n if(!x||String(x.state)!==\\\"COMPLETE\\\")r.push(\\\"DEPENDENCY\\\");\\n }\\n for(const g of J(t.guards_json,[])){\\n if(g?.type===\\\"task_complete\\\"){\\n const x=byTask.get(String(g.id));\\n if(!x||String(x.state)!==\\\"COMPLETE\\\")r.push(\\\"TASK_GUARD\\\");\\n }\\n if(g?.type===\\\"claim_verified\\\")r.push(\\\"CLAIM_GUARD_UNVERIFIED\\\");\\n if(g?.type===\\\"artifact_present\\\")r.push(\\\"ARTIFACT_GUARD_UNVERIFIED\\\");\\n }\\n if(J(t.writes_json,[]).some((w:any)=>leasedWrites.has(String(w))))r.push(\\\"WRITE_LOCK\\\");\\n return uniq(r);\\n}\\n\\nfunction agentMatches(t:any,a:any){\\n if(String(t.workstream)!==String(a.workstream))return false;\\n if(t.assigned_agent&&String(t.assigned_agent)!==String(a.id))return false;\\n const caps=new Set(J(a.capabilities_json,[]).map(String));\\n return J(t.requires_json,[]).every((x:any)=>caps.has(String(x)));\\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 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 lease_expires_at > datetime('now') THEN 1 ELSE 0 END) AS active_lease_count,\\n SUM(CASE WHEN state='LEASED' AND lease_expires_at <= datetime('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?Number(bw.poll_age_seconds):null;\\n const bridgeState=bridgeAge===null||!Number.isFinite(bridgeAge)?\\\"UNKNOWN\\\":bridgeAge<=90?\\\"HEALTHY\\\":bridgeAge<=180?\\\"DEGRADED\\\":\\\"DOWN\\\";\\n const bridgeUsable=bridgeState===\\\"HEALTHY\\\" && Number(bq.expired_lease_count||0)===0;\\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)return {ok:false,error:\\\"NO_SNAPSHOT\\\"};\\n const s:any=snap.doc.snapshot||{},tasks:any[]=s.tasks||[],agents:any[]=s.agents||[],events:any[]=snap.doc.events||[];\\n const byTask=new Map(tasks.map(t=>[String(t.id),t]));\\n const lastEvent=Math.max(0,...events.map((e:any)=>TS(e.ts)||0));\\n const recent=agents.filter(a=>{const t=TS(a.last_seen);return t!==null&&lastEvent-t<=15*60e3});\\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 expires_at > datetime('now') ORDER BY 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 nominalSupplyAgents=heartbeatRolloutReady?recent.filter(a=>freshBrainIds.has(String(a.id))):recent;\\n // Brain-facing identities are not usable supply while the canonical bridge cannot execute claims/commits.\\n // Keep nominal identity counts for diagnosis, but fail closed on effective routed capacity.\\n const supplyAgents=bridgeUsable?nominalSupplyAgents:[];\\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 leasedWrites=new Set();\\n for(const t of leased)for(const w of J(t.writes_json,[]))leasedWrites.add(String(w));\\n\\n const structural=tasks.filter(t=>structuralReasons(t,byTask,leasedWrites).length===0);\\n const rows=structural.map(t=>({task:t,matches:supplyAgents.filter(a=>agentMatches(t,a)).map(a=>String(a.id))}));\\n const directMatchable=rows.filter(x=>x.matches.length>0);\\n const unmatched=rows.filter(x=>x.matches.length===0);\\n const legacyCapabilityBlocked=unmatched.filter(x=>J(x.task.requires_json,[]).map(String).includes(\\\"sprite_exec\\\"));\\n const provisionableUnmatched=unmatched.filter(x=>!J(x.task.requires_json,[]).map(String).includes(\\\"sprite_exec\\\"));\\n const provisionableStructural=structural.filter(t=>!J(t.requires_json,[]).map(String).includes(\\\"sprite_exec\\\"));\\n\\n const idle=supplyAgents.filter(a=>!leasedOwners.has(String(a.id)));\\n const idleRows=idle.map(a=>({agent:a,matches:structural.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\\n await sqlite.execute({sql:\\\"UPDATE agent_fabric_tickets SET state='STALE',updated_at=? WHERE state='OPEN'\\\",args:[nowIso]});\\n\\n if(!bridgeUsable){\\n await sqlite.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,priority=excluded.priority,state='OPEN',reason=excluded.reason,updated_at=excluded.updated_at\\\",\\n args:[\\\"CONTROL_PLANE_LIVENESS_DEFICIT\\\",\\\"PROVISION_MORE\\\",\\\"global\\\",null,JSON.stringify([\\\"brain_control_plane_liveness\\\"]),1,1000000000,\\\"OPEN\\\",`Canonical Brain bridge is ${bridgeState}; worker age=${bridgeAge}; ready_jobs=${Number(bq.ready_count||0)}. Restore or replace the execution control plane before counting Brain-facing agent identities as usable capacity.`,nowIso,nowIso]});\\n }\\n\\n for(const x of unmatched){\\n const t=x.task,req=J(t.requires_json,[]).map(String);\\n const legacySprite=req.includes(\\\"sprite_exec\\\");\\n // Capability migration remains useful while the control plane is down because it removes\\n // obsolete task contracts. Ordinary SPAWN_COMPATIBLE demand does not: new workers cannot\\n // claim/commit through a dead Brain bridge, so emitting spawn tickets would manufacture\\n // unusable capacity pressure and thundering-herd the failed control plane.\\n if(!bridgeUsable && !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 sqlite.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 sqlite.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+idleBlocked.length;\\n const extraNeeded=Math.max(0,lowerBoundUsefulDemand-supplyAgents.length);\\n // Do not ask the fabric to provision ordinary Brain workers while the execution control\\n // plane is unavailable. Demand remains observable in the snapshot, but only the explicit\\n // CONTROL_PLANE_LIVENESS_DEFICIT should drive provisioning until claims/commits are usable.\\n if(bridgeUsable && extraNeeded){\\n await sqlite.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 const open:any=await sqlite.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 const state={\\n schema:\\\"PROJECT_BRAIN_AGENT_FABRIC_STATE_V2\\\",\\n sampled_at:nowIso,snapshot_generation:s.generation??null,snapshot_key:snap.key,\\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 recent_agent_identities_15m:recent.length,\\n nominal_recent_agent_supply:nominalSupplyAgents.length,\\n bridge_worker_state:bridgeState,\\n bridge_worker_poll_age_seconds:bridgeAge,\\n bridge_ready_jobs:Number(bq.ready_count||0),\\n bridge_active_transport_leases:Number(bq.active_lease_count||0),\\n bridge_expired_transport_leases:Number(bq.expired_lease_count||0),\\n bridge_usable_for_brain_tasks:bridgeUsable,\\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\\\":\\\"RECENT_IDENTITY_FALLBACK_DURING_HEARTBEAT_ROLLOUT\\\",\\n effective_supply_agents:supplyAgents.length,\\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:structural.length,\\n direct_matchable_tasks:directMatchable.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:!bridgeUsable?\\\"CONTROL_PLANE_DOWN\\\":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,s.generation??null,snap.key,recent.length,recent.filter(a=>leasedOwners.has(String(a.id))).length,idle.length,structural.length,directMatchable.length,unmatched.length,idleMatchable.length,idleBlocked.length,(open.rows||[]).length,JSON.stringify(state)]});\\n console.log(JSON.stringify(state));\\n return state;\\n}\",\"capacity/fabric_state.ts\":\"import { sqlite } from \\\"https://esm.town/v/std/sqlite/main.ts\\\";\\n\\nexport default async function(){\\n const sample:any=await sqlite.execute({sql:\\\"SELECT sampled_at,snapshot_generation,state_json FROM agent_fabric_samples ORDER BY sampled_at DESC LIMIT 1\\\"});\\n const substrates:any=await sqlite.execute({sql:\\\"SELECT id,state,hard_zero_spend,max_known_slots,control,evidence,updated_at FROM agent_fabric_substrates ORDER BY id\\\"});\\n const tickets:any=await sqlite.execute({sql:\\\"SELECT id,kind,workstream,task_id,required_caps_json,desired_instances,priority,reason,updated_at FROM agent_fabric_tickets WHERE state='OPEN' ORDER BY priority DESC,id\\\"});\\n const heartbeats:any=await sqlite.execute({sql:\\\"SELECT instance_id,provider_id,brain_agent_id,workstream,state,started_at,heartbeat_at,expires_at FROM agent_fabric_execution_heartbeats WHERE state='RUNNING' AND expires_at > datetime('now') ORDER BY heartbeat_at DESC LIMIT 200\\\"});\\n let state:any=null;\\n try{state=sample.rows?.[0]?.state_json?JSON.parse(sample.rows[0].state_json):null}catch{}\\n const out={\\n schema:\\\"PROJECT_BRAIN_AGENT_FABRIC_READ_V1\\\",\\n sampled_at:sample.rows?.[0]?.sampled_at??null,\\n snapshot_generation:sample.rows?.[0]?.snapshot_generation??null,\\n state,\\n substrates:substrates.rows||[],\\n capacity_tickets:tickets.rows||[],\\n attested_live_executions:heartbeats.rows||[],\\n attested_live_execution_count:(heartbeats.rows||[]).length,\\n contract:\\\"capacity/AGENT_FABRIC_WORKER_CONTRACT_V1.md\\\",\\n note:\\\"Read-only discovery surface. It grants no Brain authority and cannot claim/commit tasks.\\\"\\n };\\n return Response.json(out,{headers:{\\\"cache-control\\\":\\\"no-store\\\",\\\"x-project-brain-surface\\\":\\\"agent-fabric-read-v1\\\"}});\\n}\",\"capacity/AGENT_FABRIC_WORKER_CONTRACT_V1.md\":\"# PROJECT BRAIN UNIVERSAL AGENT FABRIC — WORKER CONTRACT V1\\n\\nStatus: provider-neutral execution contract. This file grants no authority by itself.\\n\\n## Goal\\nAny real agent substrate may contribute cognition to Project Brain without the Brain depending on that provider's UI, session model, or product-specific identity.\\n\\nA substrate counts as capacity only after a real run succeeds.\\n\\n## Provider states\\n- PROVEN_EXECUTABLE\\n- CANDIDATE_REAL_RUN_REQUIRED\\n- FAILED_RUNTIME_REPRODUCED\\n- ECONOMICALLY_DISALLOWED\\n- PROVEN_EPHEMERAL_FALLBACK\\n\\nConfigured agents, saved prompts, schedules, or provider objects are not capacity by themselves.\\n\\n## Worker identity\\nEvery execution incarnation carries:\\n- provider_id\\n- worker_id\\n- unique instance_id\\n- brain_agent_id\\n- declared capabilities\\n- workstream\\n- started_at\\n- economic_mode\\n- provider attestation/evidence reference\\n\\nNever reuse instance_id after restart.\\n\\n## Execution heartbeat\\n\\nA worker identity is not proof that an execution is still alive.\\n\\nEach real execution incarnation SHOULD publish a nonauthority fabric heartbeat:\\n- unique instance_id;\\n- provider_id;\\n- brain_agent_id after registration;\\n- workstream;\\n- truthful capabilities;\\n- state=RUNNING;\\n- started_at;\\n- heartbeat_at;\\n- short expires_at (current rollout target: about 5 minutes).\\n\\nRefresh after consequential Brain/progress activity and before long operations when practical. On graceful end, mark the incarnation ENDED. If it disappears, expiry removes it from live capacity automatically.\\n\\nHeartbeat does NOT grant Brain authority, extend a canonical task lease, authorize recovery, or permit commit. Canonical Brain lease_generation remains the write fence.\\n\\nDuring rollout the controller reports both recent Brain identities and attested execution incarnations. It must not switch to heartbeat-only supply until adoption is high enough to avoid false undercounting.\\n\\n## Admission\\nA provider adapter must prove:\\n1. a real independent execution happened;\\n2. zero additional spend under current project constraint;\\n3. it can receive a bounded Brain bootstrap/task instruction;\\n4. it can return durable evidence;\\n5. it does not require user task reconstruction for every run;\\n6. it can be stopped/demoted when limits or failures occur.\\n\\nOnly then may it become PROVEN_EXECUTABLE.\\n\\n## Brain interaction\\nWorkers never mutate canonical state directly.\\n\\nNormal sequence:\\n1. read fabric capacity ticket / bootstrap;\\n2. register truthful Brain agent identity;\\n3. reconcile current generation;\\n4. claim only causally ready work matching actual capabilities;\\n5. receive exact canonical lease_generation;\\n6. execute;\\n7. write immutable task-progress receipts after consequential progress;\\n8. renew only with exact expected lease_generation once fencing exists;\\n9. preserve evidence + hashes;\\n10. reconcile and commit through Brain CAS;\\n11. acquire next task or yield.\\n\\nNever claim human_authority_approval.\\n\\n## Task continuity\\nAgent identity is disposable.\\n\\nProgress receipt key:\\nevidence/task_progress//lease_/seq__.json\\n\\nReceipts are append-only and include task/lease/worker identity, completed substeps, evidence URIs + hashes, falsifications, remaining unknowns, exact next action, and predecessor receipt hash.\\n\\nA successor validates canonical lease history and the receipt hash chain, then resumes from the highest valid predecessor receipt.\\n\\n## Death / replacement\\nWorker death is a scheduling event, not a project failure.\\n\\n- expired work is recovered through the verified recovery path;\\n- successor gets a new lease_generation;\\n- old incarnation renewal/commit/result must fail closed;\\n- repeated death/recovery must be idempotent.\\n\\n## Capacity tickets\\nThe fabric may emit:\\n- SPAWN_COMPATIBLE\\n- MIGRATE_OR_REBIND_CAPABILITY\\n- CREATE_INDEPENDENT_USEFUL_WORK\\n- PROVISION_MORE\\n- PROVIDER_PROBE\\n\\nCapacity tickets are nonauthority scheduling evidence. Canonical Brain remains authoritative for tasks and leases.\\n\\n## Maximum-useful-capacity policy\\nMore available agents are desirable. Direct task width is not a cap on total population.\\n\\nSurplus capacity should move to independent falsification, clean-sheet alternatives, limiting-factor discovery, evidence acquisition, architecture/mechanism search, chaos/regression/recovery tests, contradiction search, and verifier replication.\\n\\nAvoid duplication by diversifying decision nodes and information channels, not by shrinking the pool by default.\\n\\n## Economic fence\\nCurrent project rule: $0 additional out-of-pocket.\\n\\nIncluded ChatGPT/Codex allowance may be used. Optional credits, auto-top-up, paid API keys, paid managed-agent runs, and provider upgrades are forbidden unless the user changes this rule.\\n\\nWhen included allowance is exhausted, that substrate becomes temporarily unavailable.\\n\\n## Provider demotion\\nImmediately demote a substrate if:\\n- real runs repeatedly fail;\\n- billing boundary becomes ambiguous;\\n- durable results cannot be returned;\\n- identity/lease fencing cannot be preserved;\\n- recurrent manual task reconstruction remains necessary;\\n- advertised capacity cannot be reproduced.\\n\\n## Production promotion proof\\nA new substrate counts as production capacity only after:\\n1. two independent real runs execute distinct Brain-compatible tasks;\\n2. both return durable evidence;\\n3. at least one worker is killed/stopped or fails;\\n4. replacement execution resumes correctly;\\n5. no duplicate canonical commit occurs;\\n6. chain and claim graph still verify;\\n7. no additional spend occurs;\\n8. an independent reviewer reproduces the result.\\n\\n## Desired end state\\nBrain publishes demand.\\nProviders compete to supply real workers.\\nWorkers are disposable.\\nState is durable.\\nManual chat opening is fallback only.\\nProvider failure changes capacity, not project truth.\\n\"};\nfor (const [path,content] of Object.entries(docs)){\n const bytes=new TextEncoder().encode(String(content));\n const h=await crypto.subtle.digest(\"SHA-256\",bytes);\n const sha=[...new Uint8Array(h)].map(b=>b.toString(16).padStart(2,\"0\")).join(\"\");\n console.log(JSON.stringify({path,bytes:bytes.length,sha256:sha}));\n}","deleted",false,"label",[47,24],"capacity","04900e5a-0cc1-401b-9ed8-b0fe6196756a",["D",1789171012789],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","Disposable R3A3 exact cohort falsifier","imageUrl","userId","6be0fc5c-1fef-4bd6-a1e1-67a3f8c0764e","pinnedFileId","01a092e7-1539-7581-b5ef-8e522619d4aa","pinPreview","pinMigrated","screenshotVersion","likeCount","orgId","01a0715b-703f-741f-ab35-c85020e4a5e0","tursoName","04900e5a0cc1401b9ed8b0fe6196756a","tursoHostname","04900e5a0cc1401b9ed8b0fe6196756a-val-town.aws-us-east-2.turso.io","tursoMeasuredAt",["D",1789609838299],"pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_9":10,"_108":104},"org",{"_9":10,"_101":102,"_103":104,"_58":59,"_105":106,"_107":44},"branch",{"_37":91,"_11":92,"_22":30,"_93":48,"_94":-5,"_95":-5,"_96":-5,"_97":-5,"_98":-5,"_99":12,"_100":10},"isOwned",2,"main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","displayName","Mo Sadek","avatar","https://lh3.googleusercontent.com/a/ACg8ocL1eT_LHhKSg5px3nXIO6eez79aZXef466qXKh2gak-0iwrvw=s96-c","tier","free","canRestrictVals","profileImageUrl","ctx",{"_84":-5,"_142":143,"_144":145,"_146":147,"_148":44,"_149":44,"_150":44,"_151":34,"_152":-5,"_153":-7,"_154":-7,"_155":38,"_156":44,"_157":44,"_158":-5,"_159":44,"_160":44,"_161":44,"_162":-5},"ENV",{"_113":114,"_115":116,"_117":92,"_118":119,"_120":121,"_122":123,"_124":125,"_126":127,"_128":129,"_130":131,"_132":133,"_134":135,"_136":137,"_138":139,"_140":141},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","RENDER_GIT_COMMIT","c73f21da490985bff19c279eb0e09db24d688e4f","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"]