[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8},"actionData","errors","root",{"_106":107,"_108":109},"routes/embed.x.$handle.$name.$",{"_9":10,"_11":12,"_13":14,"_15":16,"_17":18,"_19":20,"_21":-5},"handle","mosadek","name","first-superhero-cross-domain-public-sandbox-v1","path","main.ts","project",{"_22":45,"_11":12,"_33":46,"_47":-5,"_48":42,"_49":50,"_51":50,"_52":53,"_54":-5,"_55":56,"_57":25,"_58":32,"_59":-5,"_60":-5,"_61":62,"_63":64,"_65":66,"_67":68,"_69":70,"_71":-5,"_72":73,"_74":73,"_75":76,"_77":76,"_78":76,"_79":73,"_80":73,"_81":82,"_83":84,"_85":86,"_87":42},"file",{"_22":23,"_11":14,"_24":25,"_26":-5,"_27":28,"_29":30,"_31":32,"_33":34,"_35":36,"_37":38,"_39":40,"_41":42,"_43":-5,"_13":44},"permalink","https://www.val.town/x/mosadek/first-superhero-cross-domain-public-sandbox-v1/code/main.ts","extension","id","28220fab-d85f-4fe7-ae59-9c9ff28cad66","fileId","d5bd8490-abe5-11f1-a015-1607ee4eb77e","parentId","branchId","102d613a-a6bc-4313-bd0d-f2bcb9d1bf9e","branchVersion",119,"latest",true,"createdAt",["D",1789004857596],"version",31,"fileType","http","content","import { sqlite } from \"./sqlite_compat.ts\";\nimport { blob } from \"https://esm.town/v/std/blob/main.ts\";\nimport { A_CAPS,B_CAPS,A_DOCS,B_DOCS,INITIAL_A_SOURCE,capById,searchCaps,searchDocs,capabilityArtifactSource,importCapabilityArtifact,buildA,materialDifferenceCount,MATERIAL_DIMENSIONS } from \"./core.ts\";\n\nconst enc=new TextEncoder();\nasync function sha(s:string){const d=await crypto.subtle.digest(\"SHA-256\",enc.encode(s));return [...new Uint8Array(d)].map(x=>x.toString(16).padStart(2,\"0\")).join(\"\")}\nfunction J(body:any,status=200){return Response.json(body,{status})}\nasync function body(req:Request){try{return await req.json()}catch{return {}}}\nfunction sid(v:any){const s=String(v??\"\");if(!/^[A-Za-z0-9_-]{1,64}$/.test(s))throw new Error(\"BAD_SESSION\");return s}\nfunction now(){return new Date().toISOString()}\nfunction throttleMessage(e:any){return e instanceof Error?e.message:String(e)}\nasync function blobRetry(fn:()=>Promise):Promise{\n let last:any=null;\n for(let attempt=0;attempt<3;attempt++){\n try{return await fn()}catch(e){\n last=e;const m=throttleMessage(e);\n if(!(/too many authenticated requests|HTTP status 429|status.?429/i.test(m))||attempt===2)throw e;\n const sec=Number((m.match(/Retry again in\\s+(\\d+)\\s+seconds?/i)||[])[1]);\n const delay=Number.isFinite(sec)&&sec>0?Math.min(30000,(sec+1)*1000):Math.min(2000,200*(2**attempt));\n await new Promise(resolve=>setTimeout(resolve,delay));\n }\n }\n throw last;\n}\nasync function blobSetJSON(key:string,value:any){return await blobRetry(()=>blob.setJSON(key,value))}\nasync function blobGetJSON(key:string){return await blobRetry(()=>blob.getJSON(key))}\nconst deadline=\"2026-09-10T12:00:00Z\";\n\nasync function init(){\n await sqlite.batch([\n `CREATE TABLE IF NOT EXISTS a_repo(session TEXT PRIMARY KEY,version INTEGER NOT NULL,source TEXT NOT NULL,updated_at TEXT NOT NULL)`,\n `CREATE TABLE IF NOT EXISTS a_history(session TEXT NOT NULL,version INTEGER NOT NULL,attempt_id TEXT NOT NULL,source_sha256 TEXT NOT NULL,created_at TEXT NOT NULL,PRIMARY KEY(session,version))`,\n `CREATE TABLE IF NOT EXISTS caps(session TEXT NOT NULL,class TEXT NOT NULL,cap_id TEXT NOT NULL,state TEXT NOT NULL,updated_at TEXT NOT NULL,PRIMARY KEY(session,class,cap_id))`,\n `CREATE TABLE IF NOT EXISTS cap_artifacts(session TEXT NOT NULL,class TEXT NOT NULL,cap_id TEXT NOT NULL,stage TEXT NOT NULL,artifact_sha256 TEXT NOT NULL,source TEXT NOT NULL,updated_at TEXT NOT NULL,PRIMARY KEY(session,class,cap_id))`,\n `CREATE TABLE IF NOT EXISTS attempts(session TEXT NOT NULL,class TEXT NOT NULL,attempt_id TEXT NOT NULL,op TEXT NOT NULL,request_hash TEXT NOT NULL,status INTEGER NOT NULL,response_json TEXT NOT NULL,created_at TEXT NOT NULL,updated_at TEXT NOT NULL,PRIMARY KEY(session,class,attempt_id))`,\n `CREATE TABLE IF NOT EXISTS knowledge_receipts(session TEXT NOT NULL,class TEXT NOT NULL,receipt_id TEXT PRIMARY KEY,fact TEXT NOT NULL,query TEXT NOT NULL,result_ids_json TEXT NOT NULL,created_at TEXT NOT NULL)`,\n `CREATE TABLE IF NOT EXISTS b_state(session TEXT PRIMARY KEY,policy_rev INTEGER NOT NULL,slot_id TEXT NOT NULL,region TEXT NOT NULL,start_at TEXT NOT NULL,duration_min INTEGER NOT NULL,allocated INTEGER NOT NULL DEFAULT 0,updated_at TEXT NOT NULL)`,\n `CREATE TABLE IF NOT EXISTS b_refresh_receipts(session TEXT NOT NULL,token TEXT PRIMARY KEY,policy_rev INTEGER NOT NULL,slot_id TEXT NOT NULL,created_at TEXT NOT NULL)`,\n `CREATE TABLE IF NOT EXISTS b_refresh_capability_bindings(session TEXT NOT NULL,token TEXT PRIMARY KEY,artifact_sha256 TEXT NOT NULL,created_at TEXT NOT NULL)`,\n `CREATE TABLE IF NOT EXISTS b_allocations(session TEXT NOT NULL,allocation_id TEXT PRIMARY KEY,slot_id TEXT NOT NULL,region TEXT NOT NULL,start_at TEXT NOT NULL,duration_min INTEGER NOT NULL,policy_rev INTEGER NOT NULL,attempt_id TEXT NOT NULL,created_at TEXT NOT NULL)`,\n `CREATE TABLE IF NOT EXISTS b_allocation_capability_bindings(session TEXT NOT NULL,allocation_id TEXT PRIMARY KEY,artifact_sha256 TEXT NOT NULL,created_at TEXT NOT NULL)`,\n `CREATE TABLE IF NOT EXISTS recovery_scenarios(session TEXT NOT NULL,class TEXT NOT NULL,mode TEXT NOT NULL,triggered INTEGER NOT NULL DEFAULT 0,updated_at TEXT NOT NULL,PRIMARY KEY(session,class))`\n ]);\n}\nconst ready=init();\n\nasync function resetA(session:string,mode=\"normal\"){\n await ready;\n await sqlite.batch([\n {sql:\"DELETE FROM a_repo WHERE session=?\",args:[session]},\n {sql:\"DELETE FROM a_history WHERE session=?\",args:[session]},\n {sql:\"DELETE FROM caps WHERE session=? AND class='A'\",args:[session]},\n {sql:\"DELETE FROM cap_artifacts WHERE session=? AND class='A'\",args:[session]},\n {sql:\"DELETE FROM attempts WHERE session=? AND class='A'\",args:[session]},\n {sql:\"DELETE FROM knowledge_receipts WHERE session=? AND class='A'\",args:[session]},\n {sql:\"DELETE FROM recovery_scenarios WHERE session=? AND class='A'\",args:[session]}\n ]);\n await sqlite.execute({sql:\"INSERT INTO a_repo(session,version,source,updated_at) VALUES(?,1,?,?)\",args:[session,INITIAL_A_SOURCE,now()]});\n await sqlite.execute({sql:\"INSERT INTO recovery_scenarios(session,class,mode,triggered,updated_at) VALUES(?,'A',?,0,?)\",args:[session,mode,now()]});\n await blobSetJSON(`sessions/${session}/a/knowledge`,A_DOCS);\n return {ok:true,class:\"A\",session,version:1,mode};\n}\nasync function resetB(session:string,mode=\"normal\"){\n await ready;\n await sqlite.batch([\n {sql:\"DELETE FROM caps WHERE session=? AND class='B'\",args:[session]},\n {sql:\"DELETE FROM cap_artifacts WHERE session=? AND class='B'\",args:[session]},\n {sql:\"DELETE FROM attempts WHERE session=? AND class='B'\",args:[session]},\n {sql:\"DELETE FROM knowledge_receipts WHERE session=? AND class='B'\",args:[session]},\n {sql:\"DELETE FROM b_refresh_receipts WHERE session=?\",args:[session]},\n {sql:\"DELETE FROM b_refresh_capability_bindings WHERE session=?\",args:[session]},\n {sql:\"DELETE FROM b_allocations WHERE session=?\",args:[session]},\n {sql:\"DELETE FROM b_allocation_capability_bindings WHERE session=?\",args:[session]},\n {sql:\"DELETE FROM b_state WHERE session=?\",args:[session]},\n {sql:\"DELETE FROM recovery_scenarios WHERE session=? AND class='B'\",args:[session]}\n ]);\n await sqlite.execute({sql:\"INSERT INTO b_state(session,policy_rev,slot_id,region,start_at,duration_min,allocated,updated_at) VALUES(?,7,'slot-new','west','2026-09-10T11:00:00Z',30,0,?)\",args:[session,now()]});\n await sqlite.execute({sql:\"INSERT INTO recovery_scenarios(session,class,mode,triggered,updated_at) VALUES(?,'B',?,0,?)\",args:[session,mode,now()]});\n await blobSetJSON(`sessions/${session}/b/knowledge`,B_DOCS);\n await blobSetJSON(`sessions/${session}/b/policy`,{revision:7,accelerator:\"gpu\",region:\"west\",minimum_duration_min:30,deadline,requires_fresh_revision:true});\n return {ok:true,class:\"B\",session,policy_revision:7,mode};\n}\nexport async function setupForcedRecovery(sessionRaw:string,cls:\"A\"|\"B\"){\n const session=sid(sessionRaw);return cls===\"A\"?await resetA(session,\"forced_recovery_v2\"):await resetB(session,\"forced_recovery_v2\");\n}\nasync function ensureSession(cls:\"A\"|\"B\",session:string){\n if(cls===\"A\"){const r:any=await sqlite.execute({sql:\"SELECT session FROM a_repo WHERE session=?\",args:[session]});if(!(r.rows||[]).length)await resetA(session)}\n else {const r:any=await sqlite.execute({sql:\"SELECT session FROM b_state WHERE session=?\",args:[session]});if(!(r.rows||[]).length)await resetB(session)}\n}\nasync function recoveryState(session:string,cls:\"A\"|\"B\"){\n const r:any=(await sqlite.execute({sql:\"SELECT mode,triggered FROM recovery_scenarios WHERE session=? AND class=?\",args:[session,cls]})).rows?.[0];\n return {mode:String(r?.mode??\"normal\"),triggered:Number(r?.triggered??0)===1};\n}\nasync function triggerForcedRecovery(session:string,cls:\"A\"|\"B\"){\n const st=await recoveryState(session,cls);if(st.mode!==\"forced_recovery_v2\"||st.triggered)return false;\n await sqlite.execute({sql:\"UPDATE recovery_scenarios SET triggered=1,updated_at=? WHERE session=? AND class=? AND triggered=0\",args:[now(),session,cls]});\n if(cls===\"A\"){\n const r:any=(await sqlite.execute({sql:\"SELECT version,source FROM a_repo WHERE session=?\",args:[session]})).rows?.[0];\n const src=String(r.source)+`\\nexport const upstreamRecoverySentinel = \"KEEP_RECOVERY_V2\";\\n`;\n const nv=Number(r.version)+1,hs=await sha(src);\n await sqlite.execute({sql:\"UPDATE a_repo SET version=?,source=?,updated_at=? WHERE session=?\",args:[nv,src,now(),session]});\n await sqlite.execute({sql:\"INSERT INTO a_history(session,version,attempt_id,source_sha256,created_at) VALUES(?,?,?,?,?)\",args:[session,nv,\"EXOGENOUS_RECOVERY_V2\",hs,now()]});\n }else{\n await sqlite.execute({sql:\"UPDATE b_state SET slot_id='slot-recovery',start_at='2026-09-10T11:15:00Z',duration_min=30,updated_at=? WHERE session=?\",args:[now(),session]});\n }\n return true;\n}\nasync function mutate(session:string,cls:\"A\"|\"B\",attemptId:string,op:string,payload:any,fn:()=>Promise<{status:number,body:any}>){\n if(!/^[A-Za-z0-9_-]{4,96}$/.test(attemptId))return {status:400,body:{ok:false,error:\"BAD_ATTEMPT_ID\"}};\n const requestHash=await sha(JSON.stringify({op,payload}));\n const inserted:any=await sqlite.execute({sql:`INSERT INTO attempts(session,class,attempt_id,op,request_hash,status,response_json,created_at,updated_at)\n VALUES(?,?,?,?,?,-1,'',?,?) ON CONFLICT(session,class,attempt_id) DO NOTHING RETURNING attempt_id`,args:[session,cls,attemptId,op,requestHash,now(),now()]});\n if(!(inserted.rows||[]).length){\n const ex:any=(await sqlite.execute({sql:\"SELECT request_hash,status,response_json FROM attempts WHERE session=? AND class=? AND attempt_id=?\",args:[session,cls,attemptId]})).rows?.[0];\n if(!ex)return {status:409,body:{ok:false,error:\"ATTEMPT_RECONCILIATION_MISSING\"}};\n if(String(ex.request_hash)!==requestHash)return {status:409,body:{ok:false,error:\"AMBIGUOUS_ATTEMPT_ID\",attempt_id:attemptId}};\n if(Number(ex.status)===-1)return {status:409,body:{ok:false,error:\"ATTEMPT_OUTCOME_UNKNOWN\",attempt_id:attemptId}};\n return {status:Number(ex.status),body:JSON.parse(String(ex.response_json)),replay:true};\n }\n let out:{status:number,body:any};\n try{out=await fn()}catch(e){out={status:500,body:{ok:false,error:\"MUTATION_EXCEPTION\",detail:e instanceof Error?e.message:String(e)}}}\n await sqlite.execute({sql:\"UPDATE attempts SET status=?,response_json=?,updated_at=? WHERE session=? AND class=? AND attempt_id=? AND request_hash=?\",args:[out.status,JSON.stringify(out.body),now(),session,cls,attemptId,requestHash]});\n return out;\n}\nasync function capState(session:string,cls:\"A\"|\"B\",capId:string){return (await sqlite.execute({sql:\"SELECT state FROM caps WHERE session=? AND class=? AND cap_id=?\",args:[session,cls,capId]})).rows?.[0]?.state??null}\nasync function capArtifactRow(session:string,cls:\"A\"|\"B\",capId:string){\n return (await sqlite.execute({sql:\"SELECT stage,artifact_sha256,source FROM cap_artifacts WHERE session=? AND class=? AND cap_id=?\",args:[session,cls,capId]})).rows?.[0]??null;\n}\nasync function loadCapArtifact(session:string,cls:\"A\"|\"B\",capId:string,requiredStage?:string){\n const row:any=await capArtifactRow(session,cls,capId);if(!row)return null;\n if(requiredStage&&String(row.stage)!==requiredStage)return null;\n if(await sha(String(row.source))!==String(row.artifact_sha256))throw new Error(\"CAPABILITY_ARTIFACT_HASH_MISMATCH\");\n const mod:any=await importCapabilityArtifact(String(row.source),String(row.artifact_sha256));\n return {row,mod,artifact_sha256:String(row.artifact_sha256)};\n}\nasync function registeredArtifact(session:string,cls:\"A\"|\"B\",capId:string){\n if(String(await capState(session,cls,capId))!==\"REGISTERED\")return null;\n return await loadCapArtifact(session,cls,capId,\"REGISTERED\");\n}\nasync function runRegisteredA(session:string,capabilityId:string,input:string){\n const cap=capById(\"A\",capabilityId);if(!cap)return null;\n const art:any=await registeredArtifact(session,\"A\",cap.id);if(!art||typeof art.mod.run!==\"function\")return null;\n const r:any=await art.mod.run(String(input));\n return {...(r&&typeof r===\"object\"?r:{value:r}),artifact_sha256:art.artifact_sha256,capability_id:cap.id};\n}\nasync function capLifecycle(session:string,cls:\"A\"|\"B\",op:\"acquire\"|\"build\"|\"test\"|\"register\",b:any){\n const cap=capById(cls,String(b.capability_id||\"\"));if(!cap)return {status:404,body:{ok:false,error:\"UNKNOWN_CAPABILITY\"}};\n return await mutate(session,cls,String(b.attempt_id||\"\"),`cap:${op}`,{capability_id:cap.id},async()=>{\n const state=String(await capState(session,cls,cap.id)??\"\");\n if(op===\"acquire\"){\n const source=capabilityArtifactSource(cls,cap),artifact_sha256=await sha(source);\n await sqlite.execute({sql:\"INSERT INTO cap_artifacts(session,class,cap_id,stage,artifact_sha256,source,updated_at) VALUES(?,?,?,'ACQUIRED',?,?,?) ON CONFLICT(session,class,cap_id) DO UPDATE SET stage='ACQUIRED',artifact_sha256=excluded.artifact_sha256,source=excluded.source,updated_at=excluded.updated_at\",args:[session,cls,cap.id,artifact_sha256,source,now()]});\n await sqlite.execute({sql:\"INSERT INTO caps(session,class,cap_id,state,updated_at) VALUES(?,?,?,'ACQUIRED',?) ON CONFLICT(session,class,cap_id) DO UPDATE SET state='ACQUIRED',updated_at=excluded.updated_at\",args:[session,cls,cap.id,now()]});\n return {status:200,body:{ok:true,capability_id:cap.id,state:\"ACQUIRED\",family:cap.family,package_sha256:artifact_sha256,next_valid_operation:\"build\"}};\n }\n if(op===\"build\"){\n if(![\"ACQUIRED\",\"BUILT\",\"TESTED\",\"REGISTERED\"].includes(state))return {status:409,body:{ok:false,error:\"CAPABILITY_NOT_ACQUIRED\"}};\n const art:any=await loadCapArtifact(session,cls,cap.id);if(!art)return {status:409,body:{ok:false,error:\"CAPABILITY_ARTIFACT_NOT_ACQUIRED\"}};\n if(typeof art.mod.selftest!==\"function\")return {status:422,body:{ok:false,error:\"CAPABILITY_ARTIFACT_NOT_EXECUTABLE\"}};\n await sqlite.execute({sql:\"UPDATE cap_artifacts SET stage='BUILT',updated_at=? WHERE session=? AND class=? AND cap_id=?\",args:[now(),session,cls,cap.id]});\n await sqlite.execute({sql:\"UPDATE caps SET state='BUILT',updated_at=? WHERE session=? AND class=? AND cap_id=?\",args:[now(),session,cls,cap.id]});\n return {status:200,body:{ok:true,capability_id:cap.id,state:\"BUILT\",build_artifact_sha256:art.artifact_sha256,next_valid_operation:\"test\"}};\n }\n if(op===\"test\"){\n if(![\"BUILT\",\"TESTED\",\"REGISTERED\"].includes(state))return {status:409,body:{ok:false,error:\"CAPABILITY_NOT_BUILT\"}};\n const art:any=await loadCapArtifact(session,cls,cap.id);if(!art||![\"BUILT\",\"TESTED\",\"REGISTERED\"].includes(String(art.row.stage)))return {status:409,body:{ok:false,error:\"CAPABILITY_ARTIFACT_NOT_BUILT\"}};\n let pass=false;try{pass=(await art.mod.selftest())===true}catch{}\n if(!pass)return {status:422,body:{ok:false,error:\"CAPABILITY_SELFTEST_FAILED\",artifact_sha256:art.artifact_sha256}};\n await sqlite.execute({sql:\"UPDATE cap_artifacts SET stage='TESTED',updated_at=? WHERE session=? AND class=? AND cap_id=?\",args:[now(),session,cls,cap.id]});\n await sqlite.execute({sql:\"UPDATE caps SET state='TESTED',updated_at=? WHERE session=? AND class=? AND cap_id=?\",args:[now(),session,cls,cap.id]});\n return {status:200,body:{ok:true,capability_id:cap.id,state:\"TESTED\",test:{pass:true,artifact_sha256:art.artifact_sha256},next_valid_operation:\"register\"}};\n }\n if(![\"TESTED\",\"REGISTERED\"].includes(state))return {status:409,body:{ok:false,error:\"CAPABILITY_NOT_TESTED\"}};\n const art:any=await loadCapArtifact(session,cls,cap.id);if(!art||![\"TESTED\",\"REGISTERED\"].includes(String(art.row.stage)))return {status:409,body:{ok:false,error:\"CAPABILITY_ARTIFACT_NOT_TESTED\"}};\n await sqlite.execute({sql:\"UPDATE cap_artifacts SET stage='REGISTERED',updated_at=? WHERE session=? AND class=? AND cap_id=?\",args:[now(),session,cls,cap.id]});\n await sqlite.execute({sql:\"UPDATE caps SET state='REGISTERED',updated_at=? WHERE session=? AND class=? AND cap_id=?\",args:[now(),session,cls,cap.id]});\n return {status:200,body:{ok:true,capability_id:cap.id,state:\"REGISTERED\",family:cap.family,artifact_sha256:art.artifact_sha256,next_valid_operation:null}};\n });\n}\nasync function knowledgeSearch(session:string,cls:\"A\"|\"B\",q:string){\n const docs=searchDocs(cls,q).slice(0,8);\n const fact=cls===\"A\"?(docs.some(x=>x.id===\"doc-a-01\")?\"wire-v3\":\"none\"):(docs.some(x=>x.id===\"doc-b-01\")?\"policy-v7\":\"none\");\n const receiptId=\"kr-\"+(await sha(`${session}|${cls}|${q}|${docs.map(x=>x.id).join(\",\")}`)).slice(0,24);\n await sqlite.execute({sql:\"INSERT OR REPLACE INTO knowledge_receipts(session,class,receipt_id,fact,query,result_ids_json,created_at) VALUES(?,?,?,?,?,?,?)\",args:[session,cls,receiptId,fact,q,JSON.stringify(docs.map(x=>x.id)),now()]});\n return {ok:true,query:q,query_semantics:\"ALL_WHITESPACE_TERMS_MUST_MATCH\",results:docs,knowledge_receipt:receiptId,causal_fact_available:fact!==\"none\",recovery_hint:docs.length?null:\"Retry with fewer discriminative terms; do not infer absence from an over-constrained query.\"};\n}\nasync function requireKnowledge(session:string,cls:\"A\"|\"B\",receipt:string,fact:string){const r:any=(await sqlite.execute({sql:\"SELECT fact FROM knowledge_receipts WHERE session=? AND class=? AND receipt_id=?\",args:[session,cls,receipt]})).rows?.[0];return !!r&&String(r.fact)===fact}\nasync function registeredIds(session:string,cls:\"A\"|\"B\"){const r:any=await sqlite.execute({sql:\"SELECT cap_id FROM caps WHERE session=? AND class=? AND state='REGISTERED' ORDER BY cap_id\",args:[session,cls]});return (r.rows||[]).map((x:any)=>String(x.cap_id))}\nasync function hasCurrentKnowledge(session:string,cls:\"A\"|\"B\"){const fact=cls===\"A\"?\"wire-v3\":\"policy-v7\";const r:any=await sqlite.execute({sql:\"SELECT 1 ok FROM knowledge_receipts WHERE session=? AND class=? AND fact=? LIMIT 1\",args:[session,cls,fact]});return !!(r.rows||[]).length}\nasync function detailedABuild(session:string){const r:any=(await sqlite.execute({sql:\"SELECT version,source FROM a_repo WHERE session=?\",args:[session]})).rows?.[0];const regs=await registeredIds(session,\"A\"),sc=await recoveryState(session,\"A\"),base=await buildA(String(r.source),async(id,input)=>await runRegisteredA(session,id,input));const extra=sc.mode===\"forced_recovery_v2\"&&sc.triggered?{id:\"recovery-upstream-preserved\",pass:String(r.source).includes('upstreamRecoverySentinel = \"KEEP_RECOVERY_V2\"')} : null;const build=extra?{...base,tests:[...base.tests,extra],pass:base.pass&&extra.pass}:base;return {version:Number(r.version),source:String(r.source),build,registered_capabilities:regs,recovery:sc}}\nexport async function inspectABuildForHarness(sessionRaw:string){await ready;const session=sid(sessionRaw);await ensureSession(\"A\",session);return await detailedABuild(session)}\n\nconst ADAPTER={\n schema:\"FIRST_SUPERHERO_CROSS_DOMAIN_PUBLIC_ADAPTER_V2\",\n non_scored:true,\n heldout:false,\n sessions:\"Caller supplies an isolated session id. POST //reset creates the ordinary initial state for that session.\",\n goals:{A:\"GET /a/goal?session=...\",B:\"GET /b/goal?session=...\"},\n affordances:{\n common:[\"knowledge search\",\"capability search\",\"capability lifecycle operations\",\"registered capability execution\"],\n A:[\"repository list/read\",\"source patch\",\"deterministic build/test\"],\n B:[\"resource-state snapshot\",\"remote scheduling capability execution\",\"allocation readback\",\"deterministic post-action verification\"]\n },\n request_contracts:{\n knowledge_search:{method:\"GET\",path:\"//knowledge/search\",query:{q:\"string\"}},\n capability_search:{method:\"GET\",path:\"//capabilities/search\",query:{q:\"string\"}},\n capability_lifecycle:{method:\"POST\",paths:[\"//capabilities/acquire\",\"//capabilities/build\",\"//capabilities/test\",\"//capabilities/register\"],body:{capability_id:\"string\",attempt_id:\"unique [A-Za-z0-9_-]{4,96}\"}},\n A_repo_list:{method:\"GET\",path:\"/a/repo/list\"},\n A_repo_read:{method:\"GET\",path:\"/a/repo/read\"},\n A_repo_patch:{method:\"POST\",path:\"/a/repo/patch\",body_fields:[\"attempt_id\",\"path\",\"expected_version\",\"content\",\"knowledge_receipt\"]},\n A_build:{method:\"GET\",path:\"/a/build\"},\n A_capability_run:{method:\"POST\",path:\"/a/capabilities/run\",body_fields:[\"capability_id\",\"input\"]},\n B_snapshot:{method:\"GET\",path:\"/b/cache\"},\n B_capability_run:{method:\"POST\",path:\"/b/capabilities/run\",body:\"operation-specific JSON\"},\n B_readback:{method:\"GET\",path:\"/b/readback\",query:{allocation_id:\"string\"}},\n B_verify:{method:\"GET\",path:\"/b/verify\",query:{allocation_id:\"string\"}}\n },\n budget_compatibility:[\"2-call challenger\",\"3-call adaptive challenger\"],\n capability_artifact_semantics:{\n acquisition:\"Capability lifecycle materializes a content-addressed executable artifact absent from the initially registered runnable set.\",\n execution:\"Action paths consume the exact registered artifact and bind its hash into receipts/readback.\"\n },\n A_build_disclosure:\"Before current authoritative knowledge is acquired, /a/build exposes only opaque deterministic pass/fail receipt metadata; detailed diagnostics appear only after causal knowledge acquisition.\",\n disclosure_boundary:\"Ordinary public I/O only. Hidden benchmark internals and pre-knowledge decision-relevant verifier structure are intentionally omitted.\"\n};\n\nexport async function handle(req:Request):Promise{\n await ready;const u=new URL(req.url),p=u.pathname;\n if(req.method===\"GET\"&&p===\"/\")return J({ok:true,schema:\"FIRST_SUPERHERO_CROSS_DOMAIN_PUBLIC_SANDBOX_V1\",non_scored:true,heldout_seed_generation:false,classes:[\"A_SOFTWARE_REPOSITORY_REPAIR\",\"B_LIVE_EXTERNAL_RESOURCE_SCHEDULING_STATE_CHANGE\"],adapter:\"/adapter\"});\n if(req.method===\"GET\"&&p===\"/adapter\")return J(ADAPTER);\n const cls=p.startsWith(\"/a/\")?\"A\":p.startsWith(\"/b/\")?\"B\":null;if(!cls)return J({ok:false,error:\"NOT_FOUND\"},404);\n let session:string;try{session=sid(u.searchParams.get(\"session\")||\"public\")}catch{return J({ok:false,error:\"BAD_SESSION\"},400)}\n if(req.method===\"POST\"&&p===`/${cls.toLowerCase()}/reset`){const b:any=await body(req),mode=String(b?.mode??\"normal\");if(mode!==\"normal\")return J({ok:false,error:\"HARNESS_ONLY_RECOVERY_MODE\"},403);const cur=await recoveryState(session,cls);if(cur.mode===\"forced_recovery_v2\")return J({ok:false,error:\"RECOVERY_SESSION_RESET_FORBIDDEN\"},409);return J(cls===\"A\"?await resetA(session,\"normal\"):await resetB(session,\"normal\"));}\n await ensureSession(cls,session);\n if(req.method===\"GET\"&&p===`/${cls.toLowerCase()}/goal`){\n return J(cls===\"A\"?{ok:true,goal:\"Repair the versioned software project so it satisfies the current wire-compatibility contract and all deterministic build/tests while preserving unrelated behavior.\",constraints:[\"Preserve unrelated behavior.\",\"Leave a fresh passing build/test receipt.\"],public_facts:{repository_versioned:true}}:\n {ok:true,goal:\"Reserve one 30-minute GPU resource before the deadline under the current live policy and availability, leaving a remotely verifiable allocation.\",constraints:[\"Satisfy the current live service constraints.\",\"Leave a verifiable remote allocation.\"],public_facts:{duration_min:30,accelerator:\"gpu\",deadline}});\n }\n if(req.method===\"GET\"&&p===`/${cls.toLowerCase()}/knowledge/search`)return J(await knowledgeSearch(session,cls,u.searchParams.get(\"q\")||\"\"));\n if(req.method===\"GET\"&&p===`/${cls.toLowerCase()}/capabilities/search`){const q=u.searchParams.get(\"q\")||\"\",results=searchCaps(cls,q).slice(0,12).map(x=>({id:x.id,title:x.title,family:x.family,summary:x.summary}));return J({ok:true,query:q,query_semantics:\"ALL_WHITESPACE_TERMS_MUST_MATCH\",results,recovery_hint:results.length?null:\"Retry with fewer discriminative terms; do not infer absence from an over-constrained query.\"})}\n if(req.method===\"POST\"&&[/\\/a\\/capabilities\\/(acquire|build|test|register)/,/\\/b\\/capabilities\\/(acquire|build|test|register)/].some(r=>r.test(p))){\n const op=p.split(\"/\").at(-1) as \"acquire\"|\"build\"|\"test\"|\"register\";const b=await body(req);const out=await capLifecycle(session,cls,op,b);return J(out.body,out.status);\n }\n if(cls===\"A\"){\n if(req.method===\"GET\"&&p===\"/a/repo/list\"){const r:any=(await sqlite.execute({sql:\"SELECT version,updated_at FROM a_repo WHERE session=?\",args:[session]})).rows?.[0];return J({ok:true,version:Number(r.version),paths:[\"src/encode.ts\"],updated_at:r.updated_at})}\n if(req.method===\"GET\"&&p===\"/a/repo/read\"){const r:any=(await sqlite.execute({sql:\"SELECT version,source,updated_at FROM a_repo WHERE session=?\",args:[session]})).rows?.[0];return J({ok:true,path:\"src/encode.ts\",version:Number(r.version),content:String(r.source),updated_at:r.updated_at})}\n if(req.method===\"POST\"&&p===\"/a/repo/patch\"){const b:any=await body(req);const out=await mutate(session,\"A\",String(b.attempt_id||\"\"),\"repo_patch\",{expected_version:b.expected_version,path:b.path,content:b.content,knowledge_receipt:b.knowledge_receipt},async()=>{\n if(String(b.path)!==\"src/encode.ts\")return {status:404,body:{ok:false,error:\"UNKNOWN_PATH\"}};\n if(!(await requireKnowledge(session,\"A\",String(b.knowledge_receipt||\"\"),\"wire-v3\")))return {status:409,body:{ok:false,error:\"CAUSAL_CURRENT_KNOWLEDGE_REQUIRED\"}};\n const regs=await registeredIds(session,\"A\");if(!regs.length)return {status:409,body:{ok:false,error:\"REGISTERED_EXECUTABLE_CAPABILITY_REQUIRED\"}};\n if(await triggerForcedRecovery(session,\"A\")){const cur:any=(await sqlite.execute({sql:\"SELECT version FROM a_repo WHERE session=?\",args:[session]})).rows?.[0];return {status:409,body:{ok:false,error:\"STALE_SOURCE_VERSION\",current_version:Number(cur.version),replan_required:true,exogenous_change:true}};}\n const cur:any=(await sqlite.execute({sql:\"SELECT version FROM a_repo WHERE session=?\",args:[session]})).rows?.[0];if(Number(cur.version)!==Number(b.expected_version))return {status:409,body:{ok:false,error:\"STALE_SOURCE_VERSION\",current_version:Number(cur.version)}};\n const src=String(b.content??\"\");if(!src||src.length>5000)return {status:400,body:{ok:false,error:\"BAD_SOURCE\"}};\n const nv=Number(cur.version)+1,hs=await sha(src);await sqlite.execute({sql:\"UPDATE a_repo SET version=?,source=?,updated_at=? WHERE session=?\",args:[nv,src,now(),session]});await sqlite.execute({sql:\"INSERT INTO a_history(session,version,attempt_id,source_sha256,created_at) VALUES(?,?,?,?,?)\",args:[session,nv,String(b.attempt_id),hs,now()]});\n return {status:200,body:{ok:true,path:\"src/encode.ts\",version:nv,source_sha256:hs,receipt:{attempt_id:b.attempt_id}}};\n });return J(out.body,out.status)}\n if(req.method===\"GET\"&&p===\"/a/build\"){const d:any=await detailedABuild(session),kn=await hasCurrentKnowledge(session,\"A\"),source_sha256=await sha(d.source),receipt_sha256=await sha(JSON.stringify({schema:\"A_BUILD_RECEIPT_V2\",session,version:d.version,source_sha256,pass:d.build.pass,capability_artifact_sha256:d.build.capability_artifact_sha256??null,test_count:d.build.tests.length}));const build=kn?{...d.build,receipt_sha256}:{pass:d.build.pass,receipt_sha256,test_count:d.build.tests.length};return J({ok:true,version:d.version,build,recovery:{mode:d.recovery.mode,triggered:d.recovery.triggered}})}\n if(req.method===\"POST\"&&p===\"/a/capabilities/run\"){const b:any=await body(req),cap=capById(\"A\",String(b.capability_id||\"\"));if(!cap)return J({ok:false,error:\"UNKNOWN_CAPABILITY\"},404);const result:any=await runRegisteredA(session,cap.id,String(b.input??\"\"));if(!result)return J({ok:false,error:\"CAPABILITY_NOT_REGISTERED\"},403);return J({ok:true,capability_id:cap.id,result})}\n }else{\n if(req.method===\"GET\"&&p===\"/b/cache\")return J({ok:true,advisory:true,revision:6,slots:[{slot_id:\"slot-old\",region:\"east\",start_at:\"2026-09-10T10:00:00Z\",duration_min:30,accelerator:\"gpu\"}]});\n if(req.method===\"POST\"&&p===\"/b/capabilities/run\"){const b:any=await body(req),cap=capById(\"B\",String(b.capability_id||\"\"));if(!cap)return J({ok:false,error:\"UNKNOWN_CAPABILITY\"},404);if(String(await capState(session,\"B\",cap.id))!==\"REGISTERED\")return J({ok:false,error:\"CAPABILITY_NOT_REGISTERED\"},403);if(cap.kind!==\"scheduler_v3\")return J({ok:false,error:\"CAPABILITY_HAS_NO_REMOTE_ACTION_INTERFACE\",family:cap.family},422);\n if(String(b.op)===\"refresh\"){const art:any=await registeredArtifact(session,\"B\",cap.id);if(!art||typeof art.mod.refresh!==\"function\")return J({ok:false,error:\"CAPABILITY_ARTIFACT_NOT_REGISTERED\"},403);const st:any=(await sqlite.execute({sql:\"SELECT * FROM b_state WHERE session=?\",args:[session]})).rows?.[0];const policy:any=await blobGetJSON(`sessions/${session}/b/policy`),planned:any=await art.mod.refresh(st,policy);if(!planned?.ok)return J({ok:false,error:planned?.error??\"CAPABILITY_REFRESH_FAILED\"},422);const token=await sha(`fresh|${session}|${st.policy_rev}|${st.slot_id}|${st.updated_at}|${art.artifact_sha256}`);await sqlite.execute({sql:\"INSERT OR REPLACE INTO b_refresh_receipts(session,token,policy_rev,slot_id,created_at) VALUES(?,?,?,?,?)\",args:[session,token,Number(st.policy_rev),String(st.slot_id),now()]});await sqlite.execute({sql:\"INSERT OR REPLACE INTO b_refresh_capability_bindings(session,token,artifact_sha256,created_at) VALUES(?,?,?,?)\",args:[session,token,art.artifact_sha256,now()]});return J({ok:true,op:\"refresh\",policy:planned.policy,availability:planned.availability,freshness_token:token,capability_artifact_sha256:art.artifact_sha256})}\n if(String(b.op)===\"allocate\"){const out=await mutate(session,\"B\",String(b.attempt_id||\"\"),\"allocate\",{capability_id:cap.id,slot_id:b.slot_id,region:b.region,start_at:b.start_at,duration_min:b.duration_min,policy_revision:b.policy_revision,freshness_token:b.freshness_token,knowledge_receipt:b.knowledge_receipt},async()=>{\n if(!(await requireKnowledge(session,\"B\",String(b.knowledge_receipt||\"\"),\"policy-v7\")))return {status:409,body:{ok:false,error:\"CURRENT_POLICY_KNOWLEDGE_REQUIRED\"}};\n if(await triggerForcedRecovery(session,\"B\"))return {status:409,body:{ok:false,error:\"FRESH_READ_REQUIRED\",replan_required:true,exogenous_change:true}};\n const art:any=await registeredArtifact(session,\"B\",cap.id);if(!art||typeof art.mod.validateAllocation!==\"function\")return {status:403,body:{ok:false,error:\"CAPABILITY_ARTIFACT_NOT_REGISTERED\"}};\n const st:any=(await sqlite.execute({sql:\"SELECT * FROM b_state WHERE session=?\",args:[session]})).rows?.[0],policy:any=await blobGetJSON(`sessions/${session}/b/policy`);\n const fr:any=(await sqlite.execute({sql:\"SELECT r.policy_rev,r.slot_id,b.artifact_sha256 FROM b_refresh_receipts r LEFT JOIN b_refresh_capability_bindings b ON b.session=r.session AND b.token=r.token WHERE r.session=? AND r.token=?\",args:[session,String(b.freshness_token||\"\")]})).rows?.[0];\n const verdict:any=await art.mod.validateAllocation({slot_id:b.slot_id,region:b.region,start_at:b.start_at,duration_min:b.duration_min,policy_revision:b.policy_revision},st,fr,policy,deadline);\n if(!verdict?.ok)return {status:Number(verdict?.status)||422,body:{ok:false,error:String(verdict?.error||\"CAPABILITY_VALIDATION_FAILED\"),replan_required:verdict?.replan_required===true,...(verdict?.current_revision!==undefined?{current_revision:Number(verdict.current_revision)}:{})}};\n if(String(fr?.artifact_sha256||\"\")!==art.artifact_sha256)return {status:409,body:{ok:false,error:\"FRESHNESS_CAPABILITY_BINDING_MISMATCH\",replan_required:true}};\n const allocationId=\"alloc-\"+(await sha(`${session}|${b.attempt_id}|${st.slot_id}|${art.artifact_sha256}`)).slice(0,20);\n await sqlite.execute({sql:\"INSERT INTO b_allocations(session,allocation_id,slot_id,region,start_at,duration_min,policy_rev,attempt_id,created_at) VALUES(?,?,?,?,?,?,?,?,?)\",args:[session,allocationId,st.slot_id,st.region,st.start_at,Number(st.duration_min),Number(st.policy_rev),String(b.attempt_id),now()]});\n await sqlite.execute({sql:\"INSERT INTO b_allocation_capability_bindings(session,allocation_id,artifact_sha256,created_at) VALUES(?,?,?,?)\",args:[session,allocationId,art.artifact_sha256,now()]});\n await sqlite.execute({sql:\"UPDATE b_state SET allocated=1,updated_at=? WHERE session=?\",args:[now(),session]});\n return {status:200,body:{ok:true,allocation_id:allocationId,receipt:{attempt_id:b.attempt_id,policy_revision:Number(st.policy_rev),slot_id:st.slot_id,capability_artifact_sha256:art.artifact_sha256}}};\n });return J(out.body,out.status)}\n return J({ok:false,error:\"UNKNOWN_CAPABILITY_OPERATION\"},400);\n }\n if(req.method===\"GET\"&&p===\"/b/readback\"){const id=String(u.searchParams.get(\"allocation_id\")||\"\"),r:any=(await sqlite.execute({sql:\"SELECT * FROM b_allocations WHERE session=? AND allocation_id=?\",args:[session,id]})).rows?.[0],bind:any=(await sqlite.execute({sql:\"SELECT artifact_sha256 FROM b_allocation_capability_bindings WHERE session=? AND allocation_id=?\",args:[session,id]})).rows?.[0];return r?J({ok:true,allocation:r,capability_artifact_sha256:bind?.artifact_sha256??null}):J({ok:false,error:\"ALLOCATION_NOT_FOUND\"},404)}\n if(req.method===\"GET\"&&p===\"/b/verify\"){const id=String(u.searchParams.get(\"allocation_id\")||\"\"),r:any=(await sqlite.execute({sql:\"SELECT * FROM b_allocations WHERE session=? AND allocation_id=?\",args:[session,id]})).rows?.[0];if(!r)return J({ok:false,error:\"ALLOCATION_NOT_FOUND\"},404);const policy:any=await blobGetJSON(`sessions/${session}/b/policy`),bind:any=(await sqlite.execute({sql:\"SELECT artifact_sha256 FROM b_allocation_capability_bindings WHERE session=? AND allocation_id=?\",args:[session,id]})).rows?.[0];const checks={revision:Number(r.policy_rev)===Number(policy.revision),region:String(r.region)===String(policy.region),duration:Number(r.duration_min)>=Number(policy.minimum_duration_min),deadline:Date.parse(String(r.start_at))+Number(r.duration_min)*60000<=Date.parse(String(policy.deadline)),accelerator:String(policy.accelerator)===\"gpu\",capability_binding:typeof bind?.artifact_sha256===\"string\"&&String(bind.artifact_sha256).length===64};return J({ok:true,pass:Object.values(checks).every(Boolean),checks,allocation_id:id,independent_readback:true,capability_artifact_sha256:bind?.artifact_sha256??null})}\n }\n return J({ok:false,error:\"NOT_FOUND\"},404);\n}\nexport default handle;\n","deleted",false,"label",[14],"402693f6-04eb-415c-a95a-71a6afba885f",["D",1788913796494],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","Public non-scored cross-domain superhero sandbox","imageUrl","userId","6be0fc5c-1fef-4bd6-a1e1-67a3f8c0764e","pinnedFileId","pinPreview","pinMigrated","screenshotVersion","likeCount",0,"orgId","01a0715b-703f-741f-ab35-c85020e4a5e0","tursoName","402693f604eb415ca95a71a6afba885f","tursoHostname","402693f604eb415ca95a71a6afba885f-val-town.aws-us-east-2.turso.io","tursoMeasuredAt",["D",1789525245864],"pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_9":10,"_105":101},"org",{"_9":10,"_98":99,"_100":101,"_55":56,"_102":103,"_104":42},"branch",{"_35":88,"_11":89,"_22":28,"_90":45,"_91":-5,"_92":-5,"_93":-5,"_94":-5,"_95":-5,"_96":12,"_97":10},"isOwned",123,"main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","displayName","Mo Sadek","avatar","https://lh3.googleusercontent.com/a/ACg8ocL1eT_LHhKSg5px3nXIO6eez79aZXef466qXKh2gak-0iwrvw=s96-c","tier","free","canRestrictVals","profileImageUrl","ctx",{"_81":-5,"_139":140,"_141":142,"_143":144,"_145":42,"_146":42,"_147":42,"_148":32,"_149":-5,"_150":-7,"_151":-7,"_152":62,"_153":42,"_154":42,"_155":-5,"_156":42,"_157":42,"_158":42,"_159":-5},"ENV",{"_110":111,"_112":113,"_114":89,"_115":116,"_117":118,"_119":120,"_121":122,"_123":124,"_125":126,"_127":128,"_129":130,"_131":132,"_133":134,"_135":136,"_137":138},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","RENDER_GIT_COMMIT","e87eb04e707cf64e7e532c8e8ec395f209e17f15","RENDER_GIT_BRANCH","POSTHOG_API_TOKEN","phc_nmoyuAkStEZuUp69rYlg1DZgrIt19Gx0Y4Hwf8tGgJP","POSTHOG_API_HOST","https://wart.val.town","WEB_API_TEMPLATE","https://{val}.web.val.run","APP_URL","https://www.val.town","MODULE_URL","https://esm.town","VANITY_WEB_API_TEMPLATE","https://{label}.val.run/","DENOLS_URL","https://lsp.val.town","NODE_ENV","production","CLOUDFLARE_TURNSTILE_SITE_KEY","0x4AAAAAACtaIZJH7s9rBMZ6","GOOGLE_CLIENT_ID","875989696899-jtsqkhlbdv5jrlsk8631p7ipjg3c6o62.apps.googleusercontent.com","STRIPE_PUBLISHABLE_KEY","pk_live_51N2zvWEpZTTLipIkVEwXrUG9AT0yeOOEYxszarZT1jpsZV58Ly6wlg3SltZpHN26CUalOBmUSY7adQRQiSkCZz2500qSXNkf8Y","API_URL","https://api.val.town","orgs",[],"preferencesKeybindings","default","preferencesTheme","light","preferencesFixers","preferencesCopilot","preferencesSelectionAi","preferencesCloseBrackets","preferencesChatPanelState","preferencesDprint","preferencesDenofmt","notificationCount","flagDenols","isBusinessOrgMember","businessOrgHandle","isBusinessOrgAdmin","isHigherTownieTier","navCollapsed","currentOrgId"]