[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_271":272,"_273":274},"routes/_app.x.$handle.$name",{"_100":99,"_32":45,"_109":90,"_27":110,"_13":14,"_111":-5,"_11":112,"_113":114,"_115":116,"_117":118,"_119":120,"_20":-5,"_121":-5,"_122":-5,"_123":25,"_124":125,"_126":59,"_127":-5,"_128":-5,"_129":130},"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":57,"_58":59,"_60":-5,"_61":-5,"_62":63,"_64":65,"_66":67,"_68":69,"_70":71,"_72":-5,"_73":74,"_75":74,"_76":77,"_78":77,"_79":77,"_80":74,"_81":74,"_82":83,"_84":85,"_86":87,"_88":25},"version",38,"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","codex_bridge.ts","latestPath","fileId","2494efb0-a2b1-11f1-a91a-1607ee4eb77e","name","fileType","http","content","import OpenAI from \"npm:openai\";\nimport { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\nimport { getOpenAIKey, openAIKeyStatus } from \"./openai_runtime_key.ts\";\n\nconst TOKEN = Deno.env.get(\"EXECUTION_APPROVAL_TOKEN\");\nconst MODEL = \"gpt-5.3-codex\";\n\nfunction auth(req: Request) {\n return Boolean(TOKEN && req.headers.get(\"authorization\") === `Bearer ${TOKEN}`);\n}\n\nasync function ensure() {\n await sqlite.execute(`CREATE TABLE IF NOT EXISTS codex_assist_queue (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n agent_id TEXT NOT NULL,\n mission_stage TEXT NOT NULL,\n task_type TEXT NOT NULL,\n objective TEXT NOT NULL,\n context TEXT,\n acceptance_criteria TEXT NOT NULL,\n state TEXT NOT NULL DEFAULT 'QUEUED',\n created_at TEXT NOT NULL,\n started_at TEXT,\n completed_at TEXT,\n result_ref TEXT,\n result_text TEXT,\n error TEXT\n )`);\n}\n\nexport default async function(req: Request): Promise {\n await ensure();\n const url = new URL(req.url);\n\n if (req.method === \"GET\" && url.pathname === \"/status\") {\n const q = await sqlite.execute(`SELECT state,COUNT(*) AS n FROM codex_assist_queue GROUP BY state ORDER BY state`);\n const keyStatus = await openAIKeyStatus();\n return Response.json({\n layer:\"IMPERIAL_CODEX_ASSIST_v1\",\n model:MODEL,\n profiles:100,\n apiCredential:keyStatus,\n liveModelReady:keyStatus===\"PRESENT_WRAPPED\",\n authority:\"ASSIST_ONLY_NO_INDEPENDENT_AUTHORITY\",\n queue:q.rows\n });\n }\n\n if (!auth(req)) return Response.json({error:\"UNAUTHORIZED\"},{status:401});\n\n if (req.method === \"POST\" && url.pathname === \"/enqueue\") {\n const b = await req.json().catch(()=>null) as any;\n const agentId = String(b?.agent_id ?? \"\");\n const taskType = String(b?.task_type ?? \"\");\n const objective = String(b?.objective ?? \"\");\n const stage = String(b?.mission_stage ?? \"UNKNOWN\");\n const context = String(b?.context ?? \"\");\n const acceptance = String(b?.acceptance_criteria ?? \"\");\n if (!agentId || !taskType || !objective || !acceptance) return Response.json({error:\"REQUIRED_FIELDS_MISSING\"},{status:400});\n const p = await sqlite.execute({sql:`SELECT enabled FROM codex_assist_profile WHERE agent_id=?`,args:[agentId]});\n if (!p.rows.length || Number((p.rows[0] as any).enabled)!==1) return Response.json({error:\"CODEX_NOT_ENABLED_FOR_AGENT\"},{status:403});\n const now = new Date().toISOString();\n const r = await sqlite.execute({sql:`INSERT INTO codex_assist_queue(agent_id,mission_stage,task_type,objective,context,acceptance_criteria,state,created_at) VALUES(?,?,?,?,?,?,?,?)`,args:[agentId,stage,taskType,objective,context,acceptance,\"QUEUED\",now]});\n return Response.json({queued:true,id:Number(r.lastInsertRowid),model:MODEL});\n }\n\n if (req.method === \"POST\" && url.pathname === \"/run-next\") {\n const apiKey = await getOpenAIKey();\n if (!apiKey) return Response.json({error:\"OPENAI_API_KEY_MISSING\",liveModelReady:false},{status:503});\n const q = await sqlite.execute(`SELECT * FROM codex_assist_queue WHERE state='QUEUED' ORDER BY id LIMIT 1`);\n if (!q.rows.length) return Response.json({state:\"EMPTY\"});\n const t:any = q.rows[0];\n const now = new Date().toISOString();\n await sqlite.execute({sql:`UPDATE codex_assist_queue SET state='RUNNING',started_at=? WHERE id=? AND state='QUEUED'`,args:[now,t.id]});\n try {\n const client = new OpenAI({apiKey});\n const response = await client.responses.create({\n model: MODEL,\n reasoning: {effort:\"high\"},\n input: [\n {role:\"system\",content:\"You are the Codex Assist implementation engine inside IMPERIAL Core. Solve only the bounded engineering subtask. Do not redefine business authority, approve spending, contact customers, or claim revenue. Produce implementation-ready output with tests and explicit assumptions.\"},\n {role:\"user\",content:`Agent: ${t.agent_id}\\nMission stage: ${t.mission_stage}\\nTask type: ${t.task_type}\\nObjective: ${t.objective}\\nContext: ${t.context}\\nAcceptance criteria: ${t.acceptance_criteria}`}\n ]\n } as any);\n const text = (response as any).output_text ?? JSON.stringify((response as any).output ?? []);\n const ref = `CODEX:${MODEL}:${(response as any).id ?? t.id}`;\n await sqlite.execute({sql:`UPDATE codex_assist_queue SET state='COMPLETED',completed_at=?,result_ref=?,result_text=?,error=NULL WHERE id=?`,args:[new Date().toISOString(),ref,text,t.id]});\n return Response.json({completed:true,id:t.id,result_ref:ref,model:MODEL,output:text});\n } catch(e) {\n const err = String(e instanceof Error ? e.message : e);\n await sqlite.execute({sql:`UPDATE codex_assist_queue SET state='FAILED',completed_at=?,error=? WHERE id=?`,args:[new Date().toISOString(),err,t.id]});\n return Response.json({completed:false,id:t.id,error:err},{status:502});\n }\n }\n\n if (req.method === \"GET\" && url.pathname === \"/result\") {\n const id = Number(url.searchParams.get(\"id\"));\n if (!Number.isInteger(id)) return Response.json({error:\"INVALID_ID\"},{status:400});\n const r = await sqlite.execute({sql:`SELECT id,agent_id,state,result_ref,result_text,error,completed_at FROM codex_assist_queue WHERE id=?`,args:[id]});\n return Response.json(r.rows[0] ?? {error:\"NOT_FOUND\"},{status:r.rows.length?200:404});\n }\n\n return Response.json({error:\"NOT_FOUND\"},{status:404});\n}\n","import { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\n\nconst TOKEN = Deno.env.get(\"EXECUTION_APPROVAL_TOKEN\");\nconst MODE = \"CHATGPT_CODEX_PLUS_ONLY\";\n\nfunction auth(req: Request) {\n return Boolean(TOKEN && req.headers.get(\"authorization\") === `Bearer ${TOKEN}`);\n}\n\nasync function ensure() {\n await sqlite.execute(`CREATE TABLE IF NOT EXISTS codex_assist_queue (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n agent_id TEXT NOT NULL,\n mission_stage TEXT NOT NULL,\n task_type TEXT NOT NULL,\n objective TEXT NOT NULL,\n context TEXT,\n acceptance_criteria TEXT NOT NULL,\n state TEXT NOT NULL DEFAULT 'QUEUED_PLUS_HANDOFF',\n created_at TEXT NOT NULL,\n started_at TEXT,\n completed_at TEXT,\n result_ref TEXT,\n result_text TEXT,\n error TEXT\n )`);\n}\n\nexport default async function(req: Request): Promise {\n await ensure();\n const url = new URL(req.url);\n\n if (req.method === \"GET\" && url.pathname === \"/status\") {\n const q = await sqlite.execute(`SELECT state,COUNT(*) AS n FROM codex_assist_queue GROUP BY state ORDER BY state`);\n return Response.json({\n layer:\"IMPERIAL_CODEX_ASSIST_v2\",\n mode:MODE,\n profiles:100,\n externalOpenAIApi:false,\n apiBillingAllowed:false,\n automaticPaidApiCalls:false,\n authority:\"ASSIST_ONLY_NO_INDEPENDENT_AUTHORITY\",\n execution:\"USE_CODEX_INCLUDED_WITH_CHATGPT_PLAN; EXTERNAL_RUNTIME_ONLY_PREPARES_HANDOFF_TASKS\",\n queue:q.rows\n });\n }\n\n if (!auth(req)) return Response.json({error:\"UNAUTHORIZED\"},{status:401});\n\n if (req.method === \"POST\" && url.pathname === \"/enqueue\") {\n const b = await req.json().catch(()=>null) as any;\n const agentId = String(b?.agent_id ?? \"\");\n const taskType = String(b?.task_type ?? \"\");\n const objective = String(b?.objective ?? \"\");\n const stage = String(b?.mission_stage ?? \"UNKNOWN\");\n const context = String(b?.context ?? \"\");\n const acceptance = String(b?.acceptance_criteria ?? \"\");\n if (!agentId || !taskType || !objective || !acceptance) return Response.json({error:\"REQUIRED_FIELDS_MISSING\"},{status:400});\n const p = await sqlite.execute({sql:`SELECT enabled FROM codex_assist_profile WHERE agent_id=?`,args:[agentId]});\n if (!p.rows.length || Number((p.rows[0] as any).enabled)!==1) return Response.json({error:\"CODEX_NOT_ENABLED_FOR_AGENT\"},{status:403});\n const now = new Date().toISOString();\n const r = await sqlite.execute({sql:`INSERT INTO codex_assist_queue(agent_id,mission_stage,task_type,objective,context,acceptance_criteria,state,created_at) VALUES(?,?,?,?,?,?,?,?)`,args:[agentId,stage,taskType,objective,context,acceptance,\"QUEUED_PLUS_HANDOFF\",now]});\n return Response.json({queued:true,id:Number(r.lastInsertRowid),mode:MODE});\n }\n\n if (url.pathname === \"/run-next\") {\n return Response.json({error:\"EXTERNAL_API_DISABLED_PLUS_ONLY\",mode:MODE,paidApiCalls:false},{status:403});\n }\n\n if (req.method === \"GET\" && url.pathname === \"/result\") {\n const id = Number(url.searchParams.get(\"id\"));\n if (!Number.isInteger(id)) return Response.json({error:\"INVALID_ID\"},{status:400});\n const r = await sqlite.execute({sql:`SELECT id,agent_id,state,result_ref,result_text,error,completed_at FROM codex_assist_queue WHERE id=?`,args:[id]});\n return Response.json(r.rows[0] ?? {error:\"NOT_FOUND\"},{status:r.rows.length?200:404});\n }\n\n return Response.json({error:\"NOT_FOUND\"},{status:404});\n}\n","createdAt",["D",1787902943902],"branchVersion","branchId","9599e79a-1b06-4a25-a590-49e65a500be3","id","80b8839b-de86-40ee-8340-1df5edf7503f","imperial-nca-31day-runtime",["D",1787871527621],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","100-NCA 31-day bootstrap runtime","imageUrl","fe39b163-4b50-466e-82d1-8bd01133e4b6","pinnedFileId","d8315798-a2ac-11f1-ac46-1607ee4eb77e","pinPreview",true,"pinMigrated","screenshotVersion","likeCount",0,"orgId","01a03585-eb44-758d-92a4-77db1a9a243c","tursoName","80b8839bde8640ee83401df5edf7503f","tursoHostname","80b8839bde8640ee83401df5edf7503f-val-town.aws-us-east-2.turso.io","tursoMeasuredAt",["D",1789526460011],"pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_100":99,"_108":104},"org",{"_100":99,"_101":102,"_103":104,"_18":55,"_105":106,"_107":25},"branch",{"_13":89,"_32":90,"_43":42,"_91":44,"_92":-5,"_93":-5,"_94":-5,"_95":-5,"_96":-5,"_97":45,"_98":99},"isOwned",173,"main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","oromaskevic23","handle","displayName","Олександр Ромаскевич","avatar","https://lh3.googleusercontent.com/a/ACg8ocIo1MJ3hDjpQrinMIRok3d2YY1vpHgehs8m2u1_vc7pmFovRGI=s96-c","tier","free","canRestrictVals","profileImageUrl","branchName","","adoptOrgId",{"_43":44,"_32":45,"_38":266,"_47":-5,"_48":25,"_49":50,"_51":50,"_52":53,"_54":-5,"_18":55,"_56":57,"_58":59,"_60":-5,"_61":-5,"_62":63,"_64":65,"_66":67,"_68":69,"_70":267,"_72":-5,"_73":74,"_75":74,"_76":77,"_78":77,"_79":77,"_80":74,"_81":74,"_82":268,"_84":269,"_86":270,"_88":25},"tree",[225,226,227,228,229,230,231,232,233,234],"files",[225,226,227,228,229,230,231,232,233,234],"counts",{"_214":63,"_215":216,"_217":63,"_218":219,"_220":221},"contents",[131,132,133,134,135,136,137,138,139,140],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},{"_43":211,"_32":28,"_30":31,"_143":-5,"_41":42,"_40":14,"_145":59,"_38":212,"_13":153,"_33":34,"_35":37,"_24":25,"_148":-5,"_27":213},{"_43":204,"_32":205,"_30":206,"_143":-5,"_41":42,"_40":207,"_145":25,"_38":208,"_13":144,"_33":156,"_35":209,"_24":25,"_148":-5,"_27":210},{"_43":197,"_32":198,"_30":199,"_143":-5,"_41":42,"_40":200,"_145":25,"_38":201,"_13":155,"_33":34,"_35":202,"_24":25,"_148":-5,"_27":203},{"_43":190,"_32":191,"_30":192,"_143":-5,"_41":42,"_40":193,"_145":25,"_38":194,"_13":155,"_33":156,"_35":195,"_24":25,"_148":-5,"_27":196},{"_43":183,"_32":184,"_30":185,"_143":-5,"_41":42,"_40":186,"_145":59,"_38":187,"_13":63,"_33":156,"_35":188,"_24":25,"_148":-5,"_27":189},{"_43":176,"_32":177,"_30":178,"_143":-5,"_41":42,"_40":179,"_145":59,"_38":180,"_13":155,"_33":156,"_35":181,"_24":25,"_148":-5,"_27":182},{"_43":167,"_32":168,"_30":169,"_143":-5,"_41":42,"_40":170,"_145":25,"_38":171,"_13":172,"_33":173,"_35":174,"_24":25,"_148":-5,"_27":175},{"_43":159,"_32":160,"_30":161,"_143":-5,"_41":42,"_40":162,"_145":59,"_38":163,"_13":164,"_33":34,"_35":165,"_24":25,"_148":-5,"_27":166},{"_43":150,"_32":151,"_30":152,"_143":-5,"_41":42,"_40":153,"_145":59,"_38":154,"_13":155,"_33":156,"_35":157,"_24":25,"_148":-5,"_27":158},{"_43":141,"_32":142,"_30":57,"_143":-5,"_41":42,"_40":144,"_145":59,"_38":146,"_13":63,"_33":34,"_35":147,"_24":25,"_148":-5,"_27":149},"d4c1febe-264d-443d-bbc5-69546fb473f4","stripe_status.ts","parentId",6,"latest",["D",1787899867027],"import Stripe from \"npm:stripe\";\n\nexport default async function (_req: Request): Promise {\n const names = Object.keys(Deno.env.toObject()).filter(k => /stripe/i.test(k));\n const candidates = names.filter(k => /secret|api|key|token/i.test(k));\n let credentialSource: string | null = null;\n let accountId: string | null = null;\n for (const name of candidates) {\n const value = Deno.env.get(name);\n if (!value) continue;\n try {\n const stripe = new Stripe(value);\n const acct = await stripe.accounts.retrieve();\n if (acct?.id) { credentialSource = name; accountId = acct.id; break; }\n } catch {}\n }\n return Response.json({stripeEnvKeys:names, candidateCredentialKeys:candidates, readOnlyStripeAccountProbe:credentialSource?\"PASS\":\"NOT_AVAILABLE\", credentialSource, accountId: accountId ? accountId.slice(0,8)+\"…\" : null});\n}\n","label",[142],"b3eee3b0-bd81-45b3-9bc5-260927cc3553","stripe_probe.ts","c94990e2-a2ac-11f1-8630-1607ee4eb77e",5,["D",1787899855011],1,"script","import Stripe from \"npm:stripe\";\n\nexport default async function () {\n const names = Object.keys(Deno.env.toObject()).filter(k => /stripe/i.test(k));\n const candidates = names.filter(k => /secret|api|key|token/i.test(k));\n let workingKey: string | null = null;\n for (const name of candidates) {\n const value = Deno.env.get(name);\n if (!value) continue;\n try {\n const stripe = new Stripe(value);\n const acct = await stripe.accounts.retrieve();\n if (acct?.id) { workingKey = name; break; }\n } catch { /* read-only probe only */ }\n }\n return {stripeEnvKeys:names, candidateCredentialKeys:candidates, readOnlyStripeAccountProbe:workingKey ? \"PASS\" : \"NOT_AVAILABLE\", credentialSource:workingKey ? workingKey : null};\n}\n",[151],"ad4547e1-dc43-453b-a9af-7e0bbd0baabe","stripe_bridge.ts","f1795386-a2ac-11f1-b0aa-1607ee4eb77e",9,["D",1787899952245],2,"import Stripe from \"npm:stripe\";\nimport { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\n\nconst KEY = Deno.env.get(\"STRIPE_SECRET_KEY\");\nconst WHSEC = Deno.env.get(\"STRIPE_WEBHOOK_SECRET\");\nconst APPROVAL = Deno.env.get(\"EXECUTION_APPROVAL_TOKEN\");\n\nasync function ensureTables() {\n await sqlite.execute(`CREATE TABLE IF NOT EXISTS stripe_events (\n id TEXT PRIMARY KEY, type TEXT NOT NULL, created INTEGER NOT NULL,\n livemode INTEGER NOT NULL, payload TEXT NOT NULL, received_at TEXT NOT NULL\n )`);\n await sqlite.execute(`CREATE TABLE IF NOT EXISTS payment_evidence (\n evidence_id TEXT PRIMARY KEY, agent_id TEXT, customer_email TEXT,\n amount_total INTEGER, currency TEXT, payment_status TEXT,\n checkout_session_id TEXT, payment_intent_id TEXT, received_at TEXT NOT NULL,\n evidence_source TEXT NOT NULL\n )`);\n}\n\nexport default async function(req: Request): Promise {\n await ensureTables();\n const url = new URL(req.url);\n\n if (url.pathname === \"/status\") {\n return Response.json({\n stripeBridge:\"IMPERIAL_STRIPE_BRIDGE_v1\",\n apiCredential: KEY ? \"PRESENT\" : \"MISSING\",\n webhookSecret: WHSEC ? \"PRESENT\" : \"MISSING\",\n liveReady: Boolean(KEY && WHSEC),\n truthBoundary:\"No payment is counted without verified Stripe event evidence\"\n });\n }\n\n if (url.pathname === \"/create-checkout-session\" && req.method === \"POST\") {\n const supplied = req.headers.get(\"authorization\");\n if (!APPROVAL || supplied !== `Bearer ${APPROVAL}`) return Response.json({error:\"APPROVAL_REQUIRED\"},{status:401});\n if (!KEY) return Response.json({error:\"STRIPE_SECRET_KEY_MISSING\"},{status:503});\n const stripe = new Stripe(KEY);\n const body = await req.json().catch(()=>null) as any;\n const amountUsd = Number(body?.amount_usd);\n const description = String(body?.description ?? \"IMPERIAL Core service\");\n const agentId = String(body?.agent_id ?? \"UNKNOWN\");\n if (!Number.isFinite(amountUsd) || amountUsd <= 0 || amountUsd > 1000000) {\n return Response.json({error:\"INVALID_AMOUNT\"},{status:400});\n }\n const session = await stripe.checkout.sessions.create({\n mode:\"payment\",\n line_items:[{price_data:{currency:\"usd\",product_data:{name:description},unit_amount:Math.round(amountUsd*100)},quantity:1}],\n metadata:{agent_id:agentId, system:\"IMPERIAL Core\"},\n success_url:`${url.origin}/success?session_id={CHECKOUT_SESSION_ID}`,\n cancel_url:`${url.origin}/cancel`\n });\n return Response.json({id:session.id,url:session.url,status:session.status});\n }\n\n if (url.pathname === \"/webhook\" && req.method === \"POST\") {\n if (!KEY || !WHSEC) return Response.json({error:\"STRIPE_WEBHOOK_NOT_CONFIGURED\"},{status:503});\n const stripe = new Stripe(KEY);\n const signature = req.headers.get(\"stripe-signature\");\n if (!signature) return new Response(\"Missing signature\",{status:400});\n const raw = await req.text();\n let event: Stripe.Event;\n try { event = await stripe.webhooks.constructEventAsync(raw, signature, WHSEC); }\n catch { return new Response(\"Bad signature\",{status:400}); }\n await sqlite.execute({sql:`INSERT OR IGNORE INTO stripe_events(id,type,created,livemode,payload,received_at) VALUES(?,?,?,?,?,?)`,args:[event.id,event.type,event.created,event.livemode?1:0,raw,new Date().toISOString()]});\n if (event.type === \"checkout.session.completed\") {\n const s = event.data.object as Stripe.Checkout.Session;\n await sqlite.execute({sql:`INSERT OR REPLACE INTO payment_evidence(evidence_id,agent_id,customer_email,amount_total,currency,payment_status,checkout_session_id,payment_intent_id,received_at,evidence_source) VALUES(?,?,?,?,?,?,?,?,?,?)`,args:[event.id,String(s.metadata?.agent_id ?? \"UNKNOWN\"),String(s.customer_details?.email ?? \"\"),Number(s.amount_total ?? 0),String(s.currency ?? \"\"),String(s.payment_status ?? \"\"),s.id,String(s.payment_intent ?? \"\"),new Date().toISOString(),\"STRIPE_SIGNED_WEBHOOK\"]});\n }\n return Response.json({received:true,event_id:event.id,type:event.type});\n }\n\n if (url.pathname === \"/success\") return new Response(\"Payment received. Verification is being recorded.\");\n if (url.pathname === \"/cancel\") return new Response(\"Payment cancelled.\");\n return new Response(\"IMPERIAL Stripe Bridge\",{status:200});\n}\n",[160],"6bd9c2b7-f6ed-436c-a49f-24dbcd25582d","runner.ts","dc9ec438-a26a-11f1-8d34-1607ee4eb77e",24,["D",1787901772618],11,"interval","import { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\n\nconst START = \"2026-08-28T01:42:37+03:00\";\nconst END = \"2026-09-28T01:42:37+03:00\";\nconst ROUTER_VERSION = \"IMPERIAL-Revenue-Mission-Router-v4.1-LIVE\";\nconst SEARCH_VERSION = \"IMPERIAL-Strategic-Search-v1.0-LIVE\";\n\nfunction phase(day:number) {\n if (day <= 3) return \"OFFER_AND_PROOF\";\n if (day <= 7) return \"MARKET_VALIDATION\";\n if (day <= 14) return \"QUALIFIED_PIPELINE\";\n if (day <= 21) return \"DELIVERY_AND_CONVERSION\";\n if (day <= 28) return \"SCALE_PROVEN_CHANNELS\";\n return \"CLOSURE_AND_AUDIT\";\n}\n\ntype Route = {\n primary:string; fallback:string; buyer:string; proof:string; cashPath:string;\n margin:number; urgency:number; evidence:number; timeToCash:number; roleFit:number;\n};\n\nconst ROUTES:Record = {\n \"Kids Media\": {\n primary:\"B2B positive-media licensing / branded educational production\",\n fallback:\"paid localization or pilot-production package\",\n buyer:\"publishers, education platforms, family brands, broadcasters\",\n proof:\"pilot concept + story bible + safety/localization sample\",\n cashPath:\"paid pilot, production deposit, or licence deposit\",\n margin:0.78, urgency:0.58, evidence:0.72, timeToCash:0.63, roleFit:0.96\n },\n \"Dropshipping Commerce\": {\n primary:\"paid ecommerce growth diagnostic + implementation retainer\",\n fallback:\"validated product / merchandising operations package\",\n buyer:\"existing ecommerce operators and brands\",\n proof:\"store/product audit with sourced conversion and operations findings\",\n cashPath:\"paid diagnostic, then implementation retainer\",\n margin:0.72, urgency:0.82, evidence:0.78, timeToCash:0.84, roleFit:0.97\n },\n \"AI Automation\": {\n primary:\"high-ticket governed AI automation discovery + implementation\",\n fallback:\"workflow assessment and bounded prototype engagement\",\n buyer:\"SMEs and enterprise teams with repetitive high-cost workflows\",\n proof:\"workflow map + bounded prototype + eval + labelled ROI hypothesis\",\n cashPath:\"paid discovery or implementation deposit\",\n margin:0.88, urgency:0.82, evidence:0.82, timeToCash:0.78, roleFit:0.99\n },\n \"B2B Revenue\": {\n primary:\"paid RevOps / enterprise sales acceleration sprint\",\n fallback:\"account pipeline and proposal-system engagement\",\n buyer:\"B2B firms with measurable sales bottlenecks\",\n proof:\"funnel diagnosis + account map + proposal system\",\n cashPath:\"strategy sprint fee, then service retainer\",\n margin:0.84, urgency:0.90, evidence:0.84, timeToCash:0.86, roleFit:0.99\n },\n \"Creative & Digital\": {\n primary:\"premium digital production / licensing engagement\",\n fallback:\"paid concept, prototype, or design sprint\",\n buyer:\"brands, agencies, property, media and technology companies\",\n proof:\"portfolio-grade concept, prototype or visual demo\",\n cashPath:\"design/development deposit or licence fee\",\n margin:0.80, urgency:0.68, evidence:0.80, timeToCash:0.70, roleFit:0.97\n },\n \"Education\": {\n primary:\"B2B training / curriculum / enablement licence\",\n fallback:\"paid course-production or assessment-design package\",\n buyer:\"companies, schools, training providers, professional organizations\",\n proof:\"sample module + curriculum map + assessment plan\",\n cashPath:\"cohort/licence deposit or production fee\",\n margin:0.79, urgency:0.62, evidence:0.80, timeToCash:0.64, roleFit:0.98\n },\n \"Data & Market Intelligence\": {\n primary:\"paid market intelligence / competitive decision-support sprint\",\n fallback:\"research subscription or recurring intelligence brief\",\n buyer:\"operators, investors, product and strategy teams\",\n proof:\"sourced intelligence brief with confidence labels\",\n cashPath:\"paid research sprint or subscription prepayment\",\n margin:0.86, urgency:0.74, evidence:0.90, timeToCash:0.76, roleFit:0.99\n },\n \"SME Services\": {\n primary:\"paid operational diagnostic + transformation retainer\",\n fallback:\"bounded implementation package for one measurable constraint\",\n buyer:\"SMEs with measurable process, cost or growth constraints\",\n proof:\"diagnostic + control map + implementation roadmap\",\n cashPath:\"paid diagnostic, then implementation retainer\",\n margin:0.76, urgency:0.84, evidence:0.82, timeToCash:0.82, roleFit:0.98\n }\n};\n\nfunction routeScore(r:Route) {\n // Planning score only. Never a probability or revenue forecast.\n return 0.23*r.evidence + 0.22*r.roleFit + 0.20*r.timeToCash + 0.14*r.margin + 0.13*r.urgency + 0.08;\n}\n\nconst STAGES = [\n \"DEFINE_OFFER\",\n \"BUILD_PROOF\",\n \"QUALIFY_BUYERS\",\n \"PREPARE_APPROVED_OUTREACH\",\n \"HANDLE_RESPONSE_OR_RESEARCH_NEXT\",\n \"PREPARE_PROPOSAL_OR_PAID_DIAGNOSTIC\",\n \"DELIVER_OR_IMPROVE_PROOF\",\n \"VERIFY_EVIDENCE_AND_REPLAN\"\n] as const;\n\nfunction actionStage(stageIndex:number, day:number) {\n if (day >= 29) return \"AUDIT_AND_CLOSE\";\n return STAGES[Math.max(0, Math.min(STAGES.length-1, stageIndex))];\n}\n\nfunction nextAction(domain:string, stageIndex:number, day:number) {\n const r = ROUTES[domain];\n if (!r) return \"ROLE_ALIGNED_RESEARCH: define one lawful high-value offer and evidence plan\";\n const stage = actionStage(stageIndex, day);\n const m:Record = {\n DEFINE_OFFER:`lock one primary offer: ${r.primary}; keep only one fallback: ${r.fallback}`,\n BUILD_PROOF:`build/fact-check proof asset: ${r.proof}`,\n QUALIFY_BUYERS:`build a small qualified buyer queue matching: ${r.buyer}; no mass spam`,\n PREPARE_APPROVED_OUTREACH:`prepare personalized factual outreach drafts for qualified buyers; external send requires allowed connector/policy`,\n HANDLE_RESPONSE_OR_RESEARCH_NEXT:`process verified buyer replies if any; otherwise improve qualification using evidence, not volume`,\n PREPARE_PROPOSAL_OR_PAID_DIAGNOSTIC:`prepare a concrete paid proposal with cash path: ${r.cashPath}`,\n DELIVER_OR_IMPROVE_PROOF:`if a paid engagement exists, deliver governed scope; otherwise strengthen proof and buyer fit`,\n VERIFY_EVIDENCE_AND_REPLAN:`verify external evidence, reject pipeline-as-revenue, score route, then keep primary or switch to fallback`,\n AUDIT_AND_CLOSE:`audit lawful collected net revenue, evidence, refunds/chargebacks and unresolved obligations`\n };\n return `${stage}: ${m[stage]}`;\n}\n\nexport default async function (interval: Interval) {\n await sqlite.execute(`CREATE TABLE IF NOT EXISTS agents (\n agent_id TEXT PRIMARY KEY, domain TEXT NOT NULL, role TEXT NOT NULL,\n target_usd INTEGER NOT NULL DEFAULT 1000000, salman INTEGER NOT NULL DEFAULT 100,\n status TEXT NOT NULL DEFAULT 'ARMED', last_heartbeat TEXT,\n tick_count INTEGER NOT NULL DEFAULT 0, mission_day INTEGER NOT NULL DEFAULT 1,\n phase TEXT, next_action TEXT, network_ok INTEGER NOT NULL DEFAULT 0\n )`);\n\n await sqlite.execute(`CREATE TABLE IF NOT EXISTS routing_state (\n agent_id TEXT PRIMARY KEY,\n router_version TEXT NOT NULL,\n strategic_search_version TEXT NOT NULL,\n route_revision INTEGER NOT NULL DEFAULT 0,\n strategic_phase TEXT NOT NULL,\n action_stage TEXT NOT NULL,\n primary_route TEXT NOT NULL,\n fallback_route TEXT NOT NULL,\n buyer_profile TEXT NOT NULL,\n proof_asset TEXT NOT NULL,\n cash_path TEXT NOT NULL,\n planning_score REAL NOT NULL,\n next_action TEXT NOT NULL,\n next_action_at TEXT NOT NULL,\n approval_gate TEXT NOT NULL,\n evidence_gate TEXT NOT NULL,\n truth_boundary TEXT NOT NULL,\n last_replanned_at TEXT NOT NULL\n )`);\n\n await sqlite.execute(`CREATE TABLE IF NOT EXISTS agent_progress (\n agent_id TEXT PRIMARY KEY,\n stage_index INTEGER NOT NULL DEFAULT 0,\n stage_state TEXT NOT NULL DEFAULT 'WAITING_FOR_EVIDENCE',\n evidence_count INTEGER NOT NULL DEFAULT 0,\n last_evidence_ref TEXT,\n last_advanced_at TEXT\n )`);\n await sqlite.execute(`INSERT OR IGNORE INTO agent_progress(agent_id) SELECT agent_id FROM agents`);\n\n await sqlite.execute(`CREATE TABLE IF NOT EXISTS execution_queue (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n agent_id TEXT NOT NULL,\n action_stage TEXT NOT NULL,\n next_action TEXT NOT NULL,\n connector TEXT NOT NULL,\n execution_state TEXT NOT NULL,\n created_at TEXT NOT NULL,\n updated_at TEXT NOT NULL,\n evidence_ref TEXT,\n permission_decision TEXT,\n permission_reason TEXT\n )`);\n\n await sqlite.execute(`CREATE TABLE IF NOT EXISTS codex_assist_profile (\n agent_id TEXT PRIMARY KEY,\n enabled INTEGER NOT NULL DEFAULT 1,\n preferred_model TEXT NOT NULL,\n reasoning_effort TEXT NOT NULL,\n allowed_tasks TEXT NOT NULL,\n authority_rule TEXT NOT NULL,\n status TEXT NOT NULL\n )`);\n await sqlite.execute(`INSERT OR IGNORE INTO codex_assist_profile(agent_id,enabled,preferred_model,reasoning_effort,allowed_tasks,authority_rule,status)\n SELECT agent_id,1,'gpt-5.3-codex','high','code,automation,integration,prototype,test,debug,data-pipeline,landing-page,technical-proof','CODEX_ASSIST_HAS_NO_INDEPENDENT_AUTHORITY','AVAILABLE' FROM agents`);\n await sqlite.execute(`CREATE TABLE IF NOT EXISTS codex_assist_queue (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n agent_id TEXT NOT NULL,\n mission_stage TEXT NOT NULL,\n task_type TEXT NOT NULL,\n objective TEXT NOT NULL,\n context TEXT,\n acceptance_criteria TEXT NOT NULL,\n state TEXT NOT NULL DEFAULT 'QUEUED',\n created_at TEXT NOT NULL,\n started_at TEXT,\n completed_at TEXT,\n result_ref TEXT,\n result_text TEXT,\n error TEXT\n )`);\n\n const now = new Date();\n const start = new Date(START);\n const end = new Date(END);\n const day = Math.max(1, Math.min(31, Math.floor((now.getTime()-start.getTime())/86400000)+1));\n const active = now <= end;\n\n let networkOk = 0;\n const probes = [\n [\"https://www.cloudflare.com/cdn-cgi/trace\", {}],\n [\"https://api.github.com/zen\", {headers:{\"User-Agent\":\"IMPERIAL-Core-NCA-Runtime\"}}],\n ] as const;\n for (const [url, init] of probes) {\n try {\n const r = await fetch(url, {...init, signal: AbortSignal.timeout(5000)});\n if (r.ok) { networkOk = 1; break; }\n } catch { /* next independent probe */ }\n }\n\n const rows = await sqlite.execute(`SELECT a.agent_id,a.domain,a.tick_count,COALESCE(p.stage_index,0) AS stage_index FROM agents a LEFT JOIN agent_progress p ON p.agent_id=a.agent_id ORDER BY a.agent_id`);\n for (const row of rows.rows as any[]) {\n const id = String(row.agent_id);\n const d = String(row.domain);\n const stageIndex = Number(row.stage_index ?? 0);\n const r = ROUTES[d];\n const action = nextAction(d, stageIndex, day);\n const stage = actionStage(stageIndex, day);\n\n await sqlite.execute({sql:`UPDATE agents SET status=?, last_heartbeat=?, tick_count=tick_count+1,\n mission_day=?, phase=?, next_action=?, network_ok=? WHERE agent_id=?`,\n args:[active?\"RUNNING\":\"MISSION_ENDED\", now.toISOString(), day, phase(day), action, networkOk, id]});\n\n if (r) {\n await sqlite.execute({sql:`INSERT INTO routing_state(\n agent_id,router_version,strategic_search_version,route_revision,strategic_phase,action_stage,\n primary_route,fallback_route,buyer_profile,proof_asset,cash_path,planning_score,next_action,next_action_at,\n approval_gate,evidence_gate,truth_boundary,last_replanned_at)\n VALUES(?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?)\n ON CONFLICT(agent_id) DO UPDATE SET\n router_version=excluded.router_version,\n strategic_search_version=excluded.strategic_search_version,\n route_revision=routing_state.route_revision+1,\n strategic_phase=excluded.strategic_phase,\n action_stage=excluded.action_stage,\n primary_route=excluded.primary_route,\n fallback_route=excluded.fallback_route,\n buyer_profile=excluded.buyer_profile,\n proof_asset=excluded.proof_asset,\n cash_path=excluded.cash_path,\n planning_score=excluded.planning_score,\n next_action=excluded.next_action,\n next_action_at=excluded.next_action_at,\n approval_gate=excluded.approval_gate,\n evidence_gate=excluded.evidence_gate,\n truth_boundary=excluded.truth_boundary,\n last_replanned_at=excluded.last_replanned_at`,\n args:[id,ROUTER_VERSION,SEARCH_VERSION,1,phase(day),stage,r.primary,r.fallback,r.buyer,r.proof,r.cashPath,\n routeScore(r),action,now.toISOString(),\n \"EXTERNAL_SEND_SPEND_SIGN_OR_IRREVERSIBLE_ACTION_REQUIRES_ALLOWED_AUTHORITY\",\n \"COUNT_ONLY_LAWFUL_EXTERNALLY_EVIDENCED_COLLECTED_NET_REVENUE\",\n \"PLANNING_SCORE_IS_NOT_REVENUE_FORECAST_OR_GUARANTEE\",now.toISOString()]});\n }\n }\n\n await sqlite.execute(`UPDATE execution_queue\n SET execution_state='SUPERSEDED', updated_at=?\n WHERE execution_state='READY'\n AND EXISTS (\n SELECT 1 FROM routing_state rs\n WHERE rs.agent_id=execution_queue.agent_id\n AND (rs.action_stage<>execution_queue.action_stage OR rs.next_action<>execution_queue.next_action)\n )`, [now.toISOString()]);\n\n await sqlite.execute(`INSERT INTO execution_queue(\n agent_id,action_stage,next_action,connector,execution_state,created_at,updated_at,permission_decision,permission_reason\n )\n SELECT rs.agent_id,rs.action_stage,rs.next_action,\n CASE\n WHEN rs.action_stage IN ('DEFINE_OFFER','BUILD_PROOF','QUALIFY_BUYERS','HANDLE_RESPONSE_OR_RESEARCH_NEXT','VERIFY_EVIDENCE_AND_REPLAN') THEN 'RESEARCH_CRM'\n WHEN rs.action_stage='PREPARE_APPROVED_OUTREACH' THEN 'GMAIL_DRAFT'\n WHEN rs.action_stage='PREPARE_PROPOSAL_OR_PAID_DIAGNOSTIC' THEN 'CRM_STRIPE_PREP'\n ELSE 'RUNTIME_INTERNAL'\n END,\n 'READY',?,?,'ALLOW','STANDING_DELEGATION_L1_OR_PREPARATION'\n FROM routing_state rs\n WHERE NOT EXISTS (\n SELECT 1 FROM execution_queue q\n WHERE q.agent_id=rs.agent_id\n AND q.action_stage=rs.action_stage\n AND q.next_action=rs.next_action\n AND q.execution_state IN ('READY','CLAIMED')\n )`, [now.toISOString(),now.toISOString()]);\n\n await sqlite.execute(`INSERT INTO codex_assist_queue(agent_id,mission_stage,task_type,objective,context,acceptance_criteria,state,created_at)\n SELECT rs.agent_id,rs.action_stage,\n CASE WHEN rs.action_stage='BUILD_PROOF' THEN 'TECHNICAL_PROOF' ELSE 'DELIVERY_AUTOMATION' END,\n CASE WHEN rs.action_stage='BUILD_PROOF'\n THEN 'Create the smallest implementation-ready technical artifact that materially strengthens this proof asset: ' || rs.proof_asset\n ELSE 'Implement or improve the technical delivery needed for the proven engagement without expanding business scope.' END,\n 'Primary route: ' || rs.primary_route || '\\nBuyer: ' || rs.buyer_profile || '\\nCash path: ' || rs.cash_path || '\\nNCA next action: ' || rs.next_action,\n 'Return implementation-ready code/design, explicit assumptions, test plan, security checks, and completion evidence. Do not contact buyers, spend money, sign, or claim revenue.',\n 'QUEUED',?\n FROM routing_state rs\n JOIN codex_assist_profile cp ON cp.agent_id=rs.agent_id AND cp.enabled=1\n WHERE rs.action_stage IN ('BUILD_PROOF','DELIVER_OR_IMPROVE_PROOF')\n AND NOT EXISTS (\n SELECT 1 FROM codex_assist_queue cq\n WHERE cq.agent_id=rs.agent_id AND cq.mission_stage=rs.action_stage\n AND cq.state IN ('QUEUED','RUNNING','COMPLETED')\n )`, [now.toISOString()]);\n\n console.log(JSON.stringify({\n runtime:\"IMPERIAL_NCA_BOOTSTRAP\",\n agents:rows.rows.length,\n missionDay:day,\n router:ROUTER_VERSION,\n strategicSearch:SEARCH_VERSION,\n routedAgents:rows.rows.length,\n networkOk,\n at:now.toISOString()\n }));\n}\n",[168],"580af7a4-bc8b-44b0-86d4-121489353cf6","permission_manager_test.ts","be90b732-a2ae-11f1-9817-1607ee4eb77e",21,["D",1787900699441],"import { decidePermission } from './permission_manager.ts';\n\nconst base = {missionBound:true,runtimeDomainBound:true,capabilityAllowed:true,guardianPass:true};\nconst privateAction = decidePermission({...base,approvalGrantPresent:false,reversiblePrivateWorkspaceAction:true,externalSend:false,financialOrIrreversible:false});\nconst externalSend = decidePermission({...base,approvalGrantPresent:false,reversiblePrivateWorkspaceAction:false,externalSend:true,financialOrIrreversible:false});\nconst externalSendGranted = decidePermission({...base,approvalGrantPresent:true,reversiblePrivateWorkspaceAction:false,externalSend:true,financialOrIrreversible:false});\nconst spend = decidePermission({...base,approvalGrantPresent:false,reversiblePrivateWorkspaceAction:false,externalSend:false,financialOrIrreversible:true});\nconst badMission = decidePermission({...base,missionBound:false,approvalGrantPresent:true,reversiblePrivateWorkspaceAction:true,externalSend:false,financialOrIrreversible:false});\nif (privateAction!=='ALLOW') throw new Error('privateAction');\nif (externalSend!=='APPROVAL_REQUIRED') throw new Error('externalSend');\nif (externalSendGranted!=='ALLOW') throw new Error('externalSendGranted');\nif (spend!=='APPROVAL_REQUIRED') throw new Error('spend');\nif (badMission!=='DENY') throw new Error('badMission');\nconsole.log(JSON.stringify({tests:'5/5 PASS',privateAction,externalSend,externalSendGranted,spend,badMission}));\n",[177],"596600c2-4e45-4cf3-9f86-92bc8b64c769","permission_manager.ts","3bc80526-a2ae-11f1-9cf5-1607ee4eb77e",10,["D",1787900463602],"export type Decision = 'ALLOW'|'APPROVAL_REQUIRED'|'DENY';\n\nexport type PermissionContext = {\n missionBound: boolean;\n runtimeDomainBound: boolean;\n capabilityAllowed: boolean;\n guardianPass: boolean;\n approvalGrantPresent: boolean;\n reversiblePrivateWorkspaceAction: boolean;\n externalSend: boolean;\n financialOrIrreversible: boolean;\n};\n\nexport function decidePermission(c: PermissionContext): Decision {\n if (!c.missionBound || !c.runtimeDomainBound || !c.capabilityAllowed || !c.guardianPass) return 'DENY';\n if (c.financialOrIrreversible) return c.approvalGrantPresent ? 'ALLOW' : 'APPROVAL_REQUIRED';\n if (c.externalSend) return c.approvalGrantPresent ? 'ALLOW' : 'APPROVAL_REQUIRED';\n if (c.reversiblePrivateWorkspaceAction) return 'ALLOW';\n return c.approvalGrantPresent ? 'ALLOW' : 'APPROVAL_REQUIRED';\n}\n\nexport const CANON = {\n component: 'IMPERIAL Permission Manager',\n version: '1.0-LIVE',\n effectiveAuthority: 'Mission Authority ∩ AI Passport ∩ EIS ∩ Runtime Domain Policy ∩ Guardian Core ∩ Approval Gateway',\n delegationRule: 'Child Authority ⊆ Parent Mission Authority',\n noBypass: true,\n};\n",[184],"e59133d2-f7ea-4ce8-8937-e92d553430e5","openai_runtime_key.ts","5d6ec4fe-a2b2-11f1-957d-1607ee4eb77e",33,["D",1787902305715],"import { blob } from \"https://esm.town/v/std/blob/main.ts\";\n\nfunction b64ToBytes(s: string): Uint8Array {\n const bin = atob(s.replace(/\\s+/g, \"\"));\n const out = new Uint8Array(bin.length);\n for (let i = 0; i < bin.length; i++) out[i] = bin.charCodeAt(i);\n return out;\n}\n\nfunction b64urlToBytes(s: string): Uint8Array {\n const base64 = s.replace(/-/g, \"+\").replace(/_/g, \"/\") + \"=\".repeat((4 - (s.length % 4)) % 4);\n return b64ToBytes(base64);\n}\n\nexport async function getOpenAIKey(): Promise {\n const privatePkcs8B64 = Deno.env.get(\"OPENAI_KEY_WRAP_PRIVATE_PKCS8_B64\");\n if (!privatePkcs8B64) return null;\n let wrapped: string;\n try {\n wrapped = await (await blob.get(\"openai/wrapped_api_key_v1\")).text();\n } catch {\n return null;\n }\n\n const privateKey = await crypto.subtle.importKey(\n \"pkcs8\",\n b64ToBytes(privatePkcs8B64),\n { name: \"RSA-OAEP\", hash: \"SHA-256\" },\n false,\n [\"decrypt\"],\n );\n const plaintext = await crypto.subtle.decrypt(\n { name: \"RSA-OAEP\" },\n privateKey,\n b64urlToBytes(wrapped.trim()),\n );\n return new TextDecoder().decode(plaintext);\n}\n\nexport async function openAIKeyStatus() {\n try {\n const key = await getOpenAIKey();\n return key ? \"PRESENT_WRAPPED\" : \"MISSING\";\n } catch {\n return \"UNWRAP_FAILED\";\n }\n}\n",[191],"a438ef6d-3b40-456b-9496-246322a7ced4","execution_bridge.ts","4ca6bf4a-a2ae-11f1-a3f0-1607ee4eb77e",19,["D",1787900649448],"import { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\n\nconst TOKEN = Deno.env.get(\"EXECUTION_APPROVAL_TOKEN\");\n\nfunction authorized(req: Request) {\n return Boolean(TOKEN && req.headers.get(\"authorization\") === `Bearer ${TOKEN}`);\n}\n\nexport default async function(req: Request): Promise {\n if (!authorized(req)) return Response.json({error:\"UNAUTHORIZED\"},{status:401});\n const url = new URL(req.url);\n\n if (req.method === \"GET\" && url.pathname === \"/ready\") {\n const limit = Math.max(1, Math.min(100, Number(url.searchParams.get(\"limit\") ?? 20)));\n const r = await sqlite.execute({sql:`SELECT id,agent_id,action_stage,next_action,connector,execution_state,permission_decision,permission_reason,created_at FROM execution_queue WHERE execution_state='READY' ORDER BY id LIMIT ?`,args:[limit]});\n return Response.json({count:r.rows.length,actions:r.rows});\n }\n\n if (req.method === \"POST\" && url.pathname === \"/claim\") {\n const body = await req.json().catch(()=>null) as any;\n const id = Number(body?.id);\n if (!Number.isInteger(id)) return Response.json({error:\"INVALID_ID\"},{status:400});\n const r = await sqlite.execute({sql:`UPDATE execution_queue SET execution_state='CLAIMED',updated_at=? WHERE id=? AND execution_state='READY' AND permission_decision='ALLOW'`,args:[new Date().toISOString(),id]});\n return Response.json({claimed:r.rowsAffected===1});\n }\n\n if (req.method === \"POST\" && url.pathname === \"/complete\") {\n const body = await req.json().catch(()=>null) as any;\n const id = Number(body?.id);\n const evidenceRef = String(body?.evidence_ref ?? \"\");\n const outcome = String(body?.outcome ?? \"COMPLETED\");\n if (!Number.isInteger(id) || !evidenceRef) return Response.json({error:\"ID_AND_EVIDENCE_REQUIRED\"},{status:400});\n const now = new Date().toISOString();\n const r = await sqlite.execute({sql:`UPDATE execution_queue SET execution_state=?,evidence_ref=?,updated_at=? WHERE id=? AND execution_state IN ('READY','CLAIMED')`,args:[outcome,evidenceRef,now,id]});\n if (r.rowsAffected===1 && outcome==='COMPLETED') {\n await sqlite.execute({sql:`UPDATE agent_progress SET stage_index=CASE WHEN stage_index<7 THEN stage_index+1 ELSE 0 END,stage_state='WAITING_FOR_EVIDENCE',evidence_count=evidence_count+1,last_evidence_ref=?,last_advanced_at=? WHERE agent_id=(SELECT agent_id FROM execution_queue WHERE id=?)`,args:[evidenceRef,now,id]});\n }\n return Response.json({updated:r.rowsAffected===1,progressAdvanced:r.rowsAffected===1 && outcome==='COMPLETED'});\n }\n\n if (req.method === \"GET\" && url.pathname === \"/status\") {\n const q = await sqlite.execute(`SELECT execution_state,permission_decision,COUNT(*) AS n FROM execution_queue GROUP BY execution_state,permission_decision ORDER BY execution_state,permission_decision`);\n return Response.json({bridge:\"IMPERIAL_EXECUTION_BRIDGE_v1\",rows:q.rows});\n }\n\n return Response.json({error:\"NOT_FOUND\"},{status:404});\n}\n",[198],"c2c11e33-a8f5-48c1-b55f-ae5e64541611","codex_worker.ts","61518d6e-a2b1-11f1-a191-1607ee4eb77e",37,["D",1787902921441],"import OpenAI from \"npm:openai\";\nimport { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\nimport { getOpenAIKey } from \"./openai_runtime_key.ts\";\n\nconst MODEL = \"gpt-5.3-codex\";\n\nexport default async function (_interval: Interval) {\n const apiKey = await getOpenAIKey();\n if (!apiKey) {\n console.log(JSON.stringify({worker:\"IMPERIAL_CODEX_WORKER_v1\",model:MODEL,status:\"WAITING_FOR_OPENAI_API_CREDENTIAL\"}));\n return;\n }\n\n const client = new OpenAI({apiKey});\n const queued = await sqlite.execute(`SELECT * FROM codex_assist_queue\n WHERE state='QUEUED'\n OR (state='BLOCKED_BILLING' AND completed_at < datetime('now','-60 minutes'))\n ORDER BY id LIMIT 3`);\n let completed = 0;\n let failed = 0;\n\n for (const row of queued.rows as any[]) {\n const now = new Date().toISOString();\n const claim = await sqlite.execute({sql:`UPDATE codex_assist_queue SET state='RUNNING',started_at=? WHERE id=? AND state IN ('QUEUED','BLOCKED_BILLING')`,args:[now,row.id]});\n if (claim.rowsAffected !== 1) continue;\n try {\n const response = await client.responses.create({\n model:MODEL,\n reasoning:{effort:\"high\"},\n input:[\n {role:\"system\",content:\"You are the Codex Assist implementation engine inside IMPERIAL Core. Solve only this bounded engineering task. You have no authority to contact customers, approve claims, spend, transfer funds, sign, or redefine the NCA mission. Produce implementation-ready output, tests, security checks, assumptions and a concise completion checklist.\"},\n {role:\"user\",content:`Agent: ${row.agent_id}\\nMission stage: ${row.mission_stage}\\nTask type: ${row.task_type}\\nObjective: ${row.objective}\\nContext: ${row.context ?? ''}\\nAcceptance criteria: ${row.acceptance_criteria}`}\n ]\n } as any);\n const text = (response as any).output_text ?? JSON.stringify((response as any).output ?? []);\n const ref = `CODEX:${MODEL}:${(response as any).id ?? row.id}`;\n await sqlite.execute({sql:`UPDATE codex_assist_queue SET state='COMPLETED',completed_at=?,result_ref=?,result_text=?,error=NULL WHERE id=?`,args:[new Date().toISOString(),ref,text,row.id]});\n completed++;\n } catch(e) {\n const err = String(e instanceof Error ? e.message : e);\n const billingBlocked = err.includes('account is not active') || err.includes('check your billing details');\n await sqlite.execute({sql:`UPDATE codex_assist_queue SET state=?,completed_at=?,error=? WHERE id=?`,args:[billingBlocked?'BLOCKED_BILLING':'FAILED',new Date().toISOString(),err,row.id]});\n failed++;\n }\n }\n\n console.log(JSON.stringify({worker:\"IMPERIAL_CODEX_WORKER_v1\",model:MODEL,processed:queued.rows.length,completed,failed}));\n}\n",[205],"60374907-bd57-4045-b4c6-9641815f2aea",["D",1787902943902],[28],"pulls","branches",3,"forks","envVars",{"_222":153,"_224":63},"connections",{"_222":63,"_223":63},"count","unfilledCount","emptyCount",{"_43":211,"_32":28,"_30":31,"_143":-5,"_41":42,"_40":14,"_145":59,"_38":263,"_13":153,"_33":34,"_35":37,"_24":25,"_148":-5,"_236":264,"_27":265},{"_43":204,"_32":205,"_30":206,"_143":-5,"_41":42,"_40":207,"_145":25,"_38":260,"_13":144,"_33":156,"_35":209,"_24":25,"_148":-5,"_236":261,"_27":262},{"_43":197,"_32":198,"_30":199,"_143":-5,"_41":42,"_40":200,"_145":25,"_38":257,"_13":155,"_33":34,"_35":202,"_24":25,"_148":-5,"_236":258,"_27":259},{"_43":190,"_32":191,"_30":192,"_143":-5,"_41":42,"_40":193,"_145":25,"_38":254,"_13":155,"_33":156,"_35":195,"_24":25,"_148":-5,"_236":255,"_27":256},{"_43":183,"_32":184,"_30":185,"_143":-5,"_41":42,"_40":186,"_145":59,"_38":251,"_13":63,"_33":156,"_35":188,"_24":25,"_148":-5,"_236":252,"_27":253},{"_43":176,"_32":177,"_30":178,"_143":-5,"_41":42,"_40":179,"_145":59,"_38":248,"_13":155,"_33":156,"_35":181,"_24":25,"_148":-5,"_236":249,"_27":250},{"_43":167,"_32":168,"_30":169,"_143":-5,"_41":42,"_40":170,"_145":25,"_38":245,"_13":172,"_33":173,"_35":174,"_24":25,"_148":-5,"_236":246,"_27":247},{"_43":159,"_32":160,"_30":161,"_143":-5,"_41":42,"_40":162,"_145":59,"_38":242,"_13":164,"_33":34,"_35":165,"_24":25,"_148":-5,"_236":243,"_27":244},{"_43":150,"_32":151,"_30":152,"_143":-5,"_41":42,"_40":153,"_145":59,"_38":239,"_13":155,"_33":156,"_35":157,"_24":25,"_148":-5,"_236":240,"_27":241},{"_43":141,"_32":142,"_30":57,"_143":-5,"_41":42,"_40":144,"_145":59,"_38":235,"_13":63,"_33":34,"_35":147,"_24":25,"_148":-5,"_236":237,"_27":238},["D",1787899867027],"children",[],[142],["D",1787899855011],[],[151],["D",1787899952245],[],[160],["D",1787901772618],[],[168],["D",1787900699441],[],[177],["D",1787900463602],[],[184],["D",1787902305715],[],[191],["D",1787900649448],[],[198],["D",1787902921441],[],[205],["D",1787902943902],[],[28],["D",1787871527621],["D",1789526460011],{"_100":99,"_108":104},{"_100":99,"_101":102,"_103":104,"_18":55,"_105":106,"_107":25},{"_13":89,"_32":90,"_43":42,"_91":44,"_92":-5,"_93":-5,"_94":-5,"_95":-5,"_96":-5,"_97":45,"_98":99},"ctx",{"_82":-5,"_128":304,"_305":306,"_307":308,"_309":25,"_310":25,"_311":25,"_312":59,"_313":-5,"_314":-7,"_315":-7,"_316":63,"_317":25,"_318":25,"_319":-5,"_320":25,"_321":25,"_322":25,"_323":-5},"ENV",{"_275":276,"_277":278,"_279":90,"_280":281,"_282":283,"_284":285,"_286":287,"_288":289,"_290":291,"_292":293,"_294":295,"_296":297,"_298":299,"_300":301,"_302":303},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","RENDER_GIT_COMMIT","e87eb04e707cf64e7e532c8e8ec395f209e17f15","RENDER_GIT_BRANCH","POSTHOG_API_TOKEN","phc_nmoyuAkStEZuUp69rYlg1DZgrIt19Gx0Y4Hwf8tGgJP","POSTHOG_API_HOST","https://wart.val.town","WEB_API_TEMPLATE","https://{val}.web.val.run","APP_URL","https://www.val.town","MODULE_URL","https://esm.town","VANITY_WEB_API_TEMPLATE","https://{label}.val.run/","DENOLS_URL","https://lsp.val.town","NODE_ENV","production","CLOUDFLARE_TURNSTILE_SITE_KEY","0x4AAAAAACtaIZJH7s9rBMZ6","GOOGLE_CLIENT_ID","875989696899-jtsqkhlbdv5jrlsk8631p7ipjg3c6o62.apps.googleusercontent.com","STRIPE_PUBLISHABLE_KEY","pk_live_51N2zvWEpZTTLipIkVEwXrUG9AT0yeOOEYxszarZT1jpsZV58Ly6wlg3SltZpHN26CUalOBmUSY7adQRQiSkCZz2500qSXNkf8Y","API_URL","https://api.val.town",[],"preferencesKeybindings","default","preferencesTheme","light","preferencesFixers","preferencesCopilot","preferencesSelectionAi","preferencesCloseBrackets","preferencesChatPanelState","preferencesDprint","preferencesDenofmt","notificationCount","flagDenols","isBusinessOrgMember","businessOrgHandle","isBusinessOrgAdmin","isHigherTownieTier","navCollapsed","currentOrgId"]

Diff · v38