[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_295":296,"_297":298},"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",51,"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","connector_queue_read.ts","latestPath","fileId","8704a6d4-a2d1-11f1-8b6a-1607ee4eb77e","name","fileType","script","content","const EXECUTION_BRIDGE = \"https://oromaskevic23--4ca6bf4aa2ae11f1a3f01607ee4eb77e.web.val.run\";\n\nexport default async function () {\n const token = Deno.env.get(\"EXECUTION_APPROVAL_TOKEN\");\n if (!token) throw new Error(\"EXECUTION_APPROVAL_TOKEN_MISSING\");\n\n const response = await fetch(`${EXECUTION_BRIDGE}/ready?limit=100`, {\n method: \"GET\",\n headers: { authorization: `Bearer ${token}` },\n signal: AbortSignal.timeout(10_000),\n });\n\n const body = await response.json().catch(() => ({ error: \"INVALID_JSON\" }));\n if (!response.ok) {\n return { bridge: \"CONNECTOR_QUEUE_READ_v1\", ok: false, status: response.status, body, secretExposed: false };\n }\n\n const actions = Array.isArray(body?.actions)\n ? body.actions.filter((x: any) => x?.execution_state === \"READY\" && x?.permission_decision === \"ALLOW\")\n : [];\n\n return {\n bridge: \"CONNECTOR_QUEUE_READ_v1\",\n ok: true,\n secretExposed: false,\n readyAllowCount: actions.length,\n actions,\n };\n}\n","import { blob } from \"https://esm.town/v/std/blob/main.ts\";\n\nconst EXECUTION_BRIDGE = \"https://oromaskevic23--4ca6bf4aa2ae11f1a3f01607ee4eb77e.web.val.run\";\n\nexport default async function () {\n const token = Deno.env.get(\"EXECUTION_APPROVAL_TOKEN\");\n if (!token) throw new Error(\"EXECUTION_APPROVAL_TOKEN_MISSING\");\n\n const response = await fetch(`${EXECUTION_BRIDGE}/ready?limit=100`, {\n method: \"GET\",\n headers: { authorization: `Bearer ${token}` },\n signal: AbortSignal.timeout(10_000),\n });\n\n const body = await response.json().catch(() => ({ error: \"INVALID_JSON\" }));\n if (!response.ok) {\n return { bridge: \"CONNECTOR_QUEUE_READ_v1\", ok: false, status: response.status, body, secretExposed: false };\n }\n\n const actions = Array.isArray(body?.actions)\n ? body.actions.filter((x: any) => x?.execution_state === \"READY\" && x?.permission_decision === \"ALLOW\")\n : [];\n\n return {\n bridge: \"CONNECTOR_QUEUE_READ_v1\",\n ok: true,\n secretExposed: false,\n readyAllowCount: actions.length,\n actions,\n };\n}\n","createdAt",["D",1787915678119],"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":290,"_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":291,"_72":-5,"_73":74,"_75":74,"_76":77,"_78":77,"_79":77,"_80":74,"_81":74,"_82":292,"_84":293,"_86":294,"_88":25},"tree",[241,242,243,244,245,246,247,248,249,250,251,252],"files",[241,242,243,244,245,246,247,248,249,250,251,252],"counts",{"_231":63,"_232":215,"_233":63,"_234":235,"_236":237},"contents",[131,132,133,134,135,136,137,138,139,140,141,142],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},{"_43":224,"_32":225,"_30":226,"_145":-5,"_41":42,"_40":227,"_147":59,"_38":228,"_13":156,"_33":149,"_35":229,"_24":25,"_151":-5,"_27":230},{"_43":217,"_32":218,"_30":219,"_145":-5,"_41":42,"_40":220,"_147":25,"_38":221,"_13":63,"_33":34,"_35":222,"_24":25,"_151":-5,"_27":223},{"_43":213,"_32":28,"_30":31,"_145":-5,"_41":42,"_40":14,"_147":25,"_38":214,"_13":215,"_33":34,"_35":37,"_24":25,"_151":-5,"_27":216},{"_43":206,"_32":207,"_30":208,"_145":-5,"_41":42,"_40":209,"_147":25,"_38":210,"_13":158,"_33":149,"_35":211,"_24":25,"_151":-5,"_27":212},{"_43":199,"_32":200,"_30":201,"_145":-5,"_41":42,"_40":202,"_147":25,"_38":203,"_13":63,"_33":149,"_35":204,"_24":25,"_151":-5,"_27":205},{"_43":192,"_32":193,"_30":194,"_145":-5,"_41":42,"_40":195,"_147":59,"_38":196,"_13":63,"_33":34,"_35":197,"_24":25,"_151":-5,"_27":198},{"_43":185,"_32":186,"_30":187,"_145":-5,"_41":42,"_40":188,"_147":59,"_38":189,"_13":158,"_33":34,"_35":190,"_24":25,"_151":-5,"_27":191},{"_43":178,"_32":179,"_30":180,"_145":-5,"_41":42,"_40":181,"_147":59,"_38":182,"_13":63,"_33":149,"_35":183,"_24":25,"_151":-5,"_27":184},{"_43":169,"_32":170,"_30":171,"_145":-5,"_41":42,"_40":172,"_147":25,"_38":173,"_13":174,"_33":175,"_35":176,"_24":25,"_151":-5,"_27":177},{"_43":161,"_32":162,"_30":163,"_145":-5,"_41":42,"_40":164,"_147":59,"_38":165,"_13":166,"_33":149,"_35":167,"_24":25,"_151":-5,"_27":168},{"_43":153,"_32":154,"_30":155,"_145":-5,"_41":42,"_40":156,"_147":59,"_38":157,"_13":158,"_33":34,"_35":159,"_24":25,"_151":-5,"_27":160},{"_43":143,"_32":144,"_30":57,"_145":-5,"_41":42,"_40":146,"_147":59,"_38":148,"_13":63,"_33":149,"_35":150,"_24":25,"_151":-5,"_27":152},"d4c1febe-264d-443d-bbc5-69546fb473f4","stripe_status.ts","parentId",6,"latest",["D",1787899867027],"http","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",[144],"b3eee3b0-bd81-45b3-9bc5-260927cc3553","stripe_probe.ts","c94990e2-a2ac-11f1-8630-1607ee4eb77e",5,["D",1787899855011],1,"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",[154],"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",[162],"d3e9b835-0e04-4110-b66e-8f5d6a580979","runner.ts","dc9ec438-a26a-11f1-8d34-1607ee4eb77e",42,["D",1787902981046],15,"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,'ChatGPT Codex (Plus)','plan-managed','code,automation,integration,prototype,test,debug,data-pipeline,landing-page,technical-proof','CODEX_ASSIST_HAS_NO_INDEPENDENT_AUTHORITY','PLUS_ONLY' 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_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 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_PLUS_HANDOFF',?\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_PLUS_HANDOFF','HANDOFF_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",[170],"5b1eefe8-2f5d-4f03-ac20-bf7384a2913e","proof_catalog.ts","3a5dbc9c-a2b5-11f1-b6ed-1607ee4eb77e",45,["D",1787903467682],"const proofs: Record = {\n \"Kids Media\": {artifact:\"Positive Media Licensing Proof Pack\",deliverable:\"pilot concept + story bible + child-safety/localization checklist\",demonstrates:[\"positive-world creative development\",\"brand-safe content structure\",\"localization-ready production brief\"],truth:\"Capability demonstrator only; no audience or revenue claim.\"},\n \"Dropshipping Commerce\": {artifact:\"Ecommerce Growth Diagnostic Proof Pack\",deliverable:\"store audit framework + merchandising checklist + conversion hypothesis ledger\",demonstrates:[\"structured ecommerce diagnosis\",\"evidence-labelled conversion hypotheses\",\"implementation-retainer scoping\"],truth:\"No conversion uplift claimed without measured client data.\"},\n \"AI Automation\": {artifact:\"Governed AI Automation Proof Pack\",deliverable:\"workflow map + bounded automation architecture + eval/security checklist\",demonstrates:[\"workflow decomposition\",\"governed automation design\",\"test and rollback planning\"],truth:\"ROI remains a hypothesis until measured against a real client baseline.\"},\n \"B2B Revenue\": {artifact:\"RevOps Acceleration Proof Pack\",deliverable:\"funnel diagnosis template + account map + proposal-system blueprint\",demonstrates:[\"pipeline bottleneck analysis\",\"account prioritization\",\"proposal workflow design\"],truth:\"No pipeline or revenue is counted as collected revenue.\"},\n \"Creative & Digital\": {artifact:\"Premium Digital Prototype Proof Pack\",deliverable:\"concept brief + prototype specification + acceptance-test checklist\",demonstrates:[\"premium concept development\",\"prototype scoping\",\"production-quality acceptance criteria\"],truth:\"Portfolio demonstrator; no fabricated client endorsement.\"},\n \"Education\": {artifact:\"B2B Learning License Proof Pack\",deliverable:\"sample module structure + curriculum map + assessment blueprint\",demonstrates:[\"instructional architecture\",\"assessment alignment\",\"license-ready packaging\"],truth:\"Learning outcomes require real learner evaluation before claims.\"},\n \"Data & Market Intelligence\": {artifact:\"Decision Intelligence Proof Pack\",deliverable:\"source register + confidence-labelled brief template + decision matrix\",demonstrates:[\"source discipline\",\"confidence labelling\",\"decision-oriented synthesis\"],truth:\"No unsourced market facts or investment recommendations.\"},\n \"SME Services\": {artifact:\"Operational Diagnostic Proof Pack\",deliverable:\"constraint map + control checklist + implementation roadmap\",demonstrates:[\"process diagnosis\",\"risk/control mapping\",\"bounded transformation planning\"],truth:\"Savings or growth claims require client evidence.\"}\n};\n\nexport default async function(req: Request): Promise {\n const u = new URL(req.url);\n const domain = u.searchParams.get(\"domain\");\n if (domain) {\n const proof = proofs[domain];\n if (!proof) return Response.json({error:\"UNKNOWN_DOMAIN\"},{status:404});\n return Response.json({system:\"IMPERIAL Core\",evidenceClass:\"LIVE_CAPABILITY_PROOF\",domain,...proof,generatedAt:new Date().toISOString()});\n }\n return Response.json({system:\"IMPERIAL Core\",evidenceClass:\"LIVE_CAPABILITY_PROOF_CATALOG\",count:Object.keys(proofs).length,proofs,truthBoundary:\"These are capability demonstrators, not customer results, revenue evidence, endorsements, or guarantees.\"});\n}\n",[179],"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",[186],"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",[193],"61f08b92-81cf-4ed6-b720-9095806b78a1","execution_connector_adapter.ts","96660a96-a2d1-11f1-a3ae-1607ee4eb77e",49,["D",1787915648014],"import { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\n\nconst BRIDGE = \"IMPERIAL_CONNECTOR_EXECUTION_ADAPTER_v1\";\n\nexport default async function(req: Request): Promise {\n const url = new URL(req.url);\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:BRIDGE,access:\"VAL_TOWN_RESTRICTED_ORG_GATE\",secretExposed:false,rows:q.rows});\n }\n\n if (req.method === \"POST\" && url.pathname === \"/claim-next\") {\n const now = new Date().toISOString();\n const candidate = await sqlite.execute(`SELECT id FROM execution_queue WHERE execution_state='READY' AND permission_decision='ALLOW' ORDER BY id LIMIT 1`);\n if (!candidate.rows.length) return Response.json({bridge:BRIDGE,state:\"EMPTY\"});\n const id = Number((candidate.rows[0] as any).id);\n const claim = await sqlite.execute({sql:`UPDATE execution_queue SET execution_state='CLAIMED_CONNECTOR',updated_at=? WHERE id=? AND execution_state='READY' AND permission_decision='ALLOW'`,args:[now,id]});\n if (claim.rowsAffected !== 1) return Response.json({bridge:BRIDGE,state:\"RACE_RETRY\"},{status:409});\n const item = await sqlite.execute({sql:`SELECT id,agent_id,action_stage,next_action,connector,permission_decision,permission_reason,created_at,updated_at FROM execution_queue WHERE id=?`,args:[id]});\n return Response.json({bridge:BRIDGE,claimed:true,item:item.rows[0]});\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 ?? \"\").trim();\n const outcome = String(body?.outcome ?? \"COMPLETED\");\n if (!Number.isInteger(id) || !evidenceRef) return Response.json({error:\"ID_AND_EVIDENCE_REQUIRED\"},{status:400});\n if (!['COMPLETED','BLOCKED'].includes(outcome)) return Response.json({error:\"INVALID_OUTCOME\"},{status:400});\n const now = new Date().toISOString();\n const item = await sqlite.execute({sql:`SELECT id,agent_id,action_stage,permission_decision,execution_state FROM execution_queue WHERE id=?`,args:[id]});\n if (!item.rows.length) return Response.json({error:\"ITEM_NOT_FOUND\"},{status:404});\n const row:any = item.rows[0];\n if (row.execution_state !== 'CLAIMED_CONNECTOR' || row.permission_decision !== 'ALLOW') return Response.json({error:\"NOT_CONNECTOR_CLAIMED_OR_NOT_ALLOWED\"},{status:409});\n const update = await sqlite.execute({sql:`UPDATE execution_queue SET execution_state=?,evidence_ref=?,updated_at=? WHERE id=? AND execution_state='CLAIMED_CONNECTOR' AND permission_decision='ALLOW'`,args:[outcome,evidenceRef,now,id]});\n let progressAdvanced = false;\n if (update.rowsAffected===1 && outcome==='COMPLETED') {\n const p = 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=?`,args:[evidenceRef,now,row.agent_id]});\n progressAdvanced = p.rowsAffected===1;\n }\n return Response.json({bridge:BRIDGE,updated:update.rowsAffected===1,progressAdvanced,outcome,evidence_ref:evidenceRef});\n }\n\n if (req.method === \"POST\" && url.pathname === \"/release\") {\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='READY',updated_at=? WHERE id=? AND execution_state='CLAIMED_CONNECTOR' AND permission_decision='ALLOW'`,args:[new Date().toISOString(),id]});\n return Response.json({bridge:BRIDGE,released:r.rowsAffected===1});\n }\n\n return Response.json({error:\"NOT_FOUND\"},{status:404});\n}\n",[200],"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",[207],"90dcbbc8-99bb-40f5-a1b5-4fdb86d4290e",["D",1787915678119],3,[28],"d946535e-c5ec-45df-94ec-48a7e5425c00","connector_queue_claim.ts","8bcf9516-a2d1-11f1-bfbf-1607ee4eb77e",47,["D",1787915630259],"const EXECUTION_BRIDGE = \"https://oromaskevic23--4ca6bf4aa2ae11f1a3f01607ee4eb77e.web.val.run\";\nconst SUPPORTED_CONNECTORS = new Set([\"RESEARCH_CRM\", \"GMAIL_DRAFT\", \"CRM_STRIPE_PREP\", \"RUNTIME_INTERNAL\"]);\n\nexport default async function () {\n const token = Deno.env.get(\"EXECUTION_APPROVAL_TOKEN\");\n if (!token) throw new Error(\"EXECUTION_APPROVAL_TOKEN_MISSING\");\n\n const headers = { authorization: `Bearer ${token}`, \"content-type\": \"application/json\" };\n const readyResponse = await fetch(`${EXECUTION_BRIDGE}/ready?limit=100`, {\n headers,\n signal: AbortSignal.timeout(10_000),\n });\n const readyBody = await readyResponse.json().catch(() => ({ error: \"INVALID_JSON\" }));\n if (!readyResponse.ok) {\n console.log(JSON.stringify({ bridge: \"CONNECTOR_QUEUE_CLAIM_v1\", ok: false, stage: \"READ\", status: readyResponse.status, body: readyBody }));\n return;\n }\n\n const candidates = Array.isArray(readyBody?.actions)\n ? readyBody.actions.filter((x: any) => x?.execution_state === \"READY\" && x?.permission_decision === \"ALLOW\" && SUPPORTED_CONNECTORS.has(String(x?.connector)))\n : [];\n\n if (!candidates.length) {\n console.log(JSON.stringify({ bridge: \"CONNECTOR_QUEUE_CLAIM_v1\", ok: true, claimed: false, reason: \"NO_SUPPORTED_READY_ALLOW_ITEM\", secretExposed: false }));\n return;\n }\n\n const item = candidates[0];\n const claimResponse = await fetch(`${EXECUTION_BRIDGE}/claim`, {\n method: \"POST\",\n headers,\n body: JSON.stringify({ id: item.id }),\n signal: AbortSignal.timeout(10_000),\n });\n const claimBody = await claimResponse.json().catch(() => ({ error: \"INVALID_JSON\" }));\n\n console.log(JSON.stringify({\n bridge: \"CONNECTOR_QUEUE_CLAIM_v1\",\n ok: claimResponse.ok,\n claimed: Boolean(claimBody?.claimed),\n secretExposed: false,\n item: claimBody?.claimed ? item : undefined,\n status: claimResponse.status,\n error: claimResponse.ok ? undefined : claimBody,\n }));\n}\n",[218],"60374907-bd57-4045-b4c6-9641815f2aea","codex_bridge.ts","2494efb0-a2b1-11f1-a91a-1607ee4eb77e",38,["D",1787902943902],"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",[225],"pulls","branches","forks","envVars",{"_238":156,"_240":63},"connections",{"_238":63,"_239":63},"count","unfilledCount","emptyCount",{"_43":224,"_32":225,"_30":226,"_145":-5,"_41":42,"_40":227,"_147":59,"_38":287,"_13":156,"_33":149,"_35":229,"_24":25,"_151":-5,"_254":288,"_27":289},{"_43":217,"_32":218,"_30":219,"_145":-5,"_41":42,"_40":220,"_147":25,"_38":284,"_13":63,"_33":34,"_35":222,"_24":25,"_151":-5,"_254":285,"_27":286},{"_43":213,"_32":28,"_30":31,"_145":-5,"_41":42,"_40":14,"_147":25,"_38":281,"_13":215,"_33":34,"_35":37,"_24":25,"_151":-5,"_254":282,"_27":283},{"_43":206,"_32":207,"_30":208,"_145":-5,"_41":42,"_40":209,"_147":25,"_38":278,"_13":158,"_33":149,"_35":211,"_24":25,"_151":-5,"_254":279,"_27":280},{"_43":199,"_32":200,"_30":201,"_145":-5,"_41":42,"_40":202,"_147":25,"_38":275,"_13":63,"_33":149,"_35":204,"_24":25,"_151":-5,"_254":276,"_27":277},{"_43":192,"_32":193,"_30":194,"_145":-5,"_41":42,"_40":195,"_147":59,"_38":272,"_13":63,"_33":34,"_35":197,"_24":25,"_151":-5,"_254":273,"_27":274},{"_43":185,"_32":186,"_30":187,"_145":-5,"_41":42,"_40":188,"_147":59,"_38":269,"_13":158,"_33":34,"_35":190,"_24":25,"_151":-5,"_254":270,"_27":271},{"_43":178,"_32":179,"_30":180,"_145":-5,"_41":42,"_40":181,"_147":59,"_38":266,"_13":63,"_33":149,"_35":183,"_24":25,"_151":-5,"_254":267,"_27":268},{"_43":169,"_32":170,"_30":171,"_145":-5,"_41":42,"_40":172,"_147":25,"_38":263,"_13":174,"_33":175,"_35":176,"_24":25,"_151":-5,"_254":264,"_27":265},{"_43":161,"_32":162,"_30":163,"_145":-5,"_41":42,"_40":164,"_147":59,"_38":260,"_13":166,"_33":149,"_35":167,"_24":25,"_151":-5,"_254":261,"_27":262},{"_43":153,"_32":154,"_30":155,"_145":-5,"_41":42,"_40":156,"_147":59,"_38":257,"_13":158,"_33":34,"_35":159,"_24":25,"_151":-5,"_254":258,"_27":259},{"_43":143,"_32":144,"_30":57,"_145":-5,"_41":42,"_40":146,"_147":59,"_38":253,"_13":63,"_33":149,"_35":150,"_24":25,"_151":-5,"_254":255,"_27":256},["D",1787899867027],"children",[],[144],["D",1787899855011],[],[154],["D",1787899952245],[],[162],["D",1787902981046],[],[170],["D",1787903467682],[],[179],["D",1787900699441],[],[186],["D",1787900463602],[],[193],["D",1787915648014],[],[200],["D",1787900649448],[],[207],["D",1787915678119],[],[28],["D",1787915630259],[],[218],["D",1787902943902],[],[225],["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":328,"_329":330,"_331":332,"_333":25,"_334":25,"_335":25,"_336":59,"_337":-5,"_338":-7,"_339":-7,"_340":63,"_341":25,"_342":25,"_343":-5,"_344":25,"_345":25,"_346":25,"_347":-5},"ENV",{"_299":300,"_301":302,"_303":90,"_304":305,"_306":307,"_308":309,"_310":311,"_312":313,"_314":315,"_316":317,"_318":319,"_320":321,"_322":323,"_324":325,"_326":327},"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 · v51