[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_416":417,"_418":419},"routes/_app.x.$handle.$name",{"_11":12,"_13":14,"_15":16,"_18":19,"_17":-7,"_305":-5,"_20":306,"_22":307,"_308":309,"_310":311,"_26":312,"_24":313,"_314":315,"_316":317,"_318":53,"_319":320,"_321":76,"_322":-5,"_323":-5,"_324":325},"routes/_app.x.$handle.$name.branch.$branch.code.$",{"_11":12,"_13":14,"_15":16,"_17":-7,"_18":19,"_20":21,"_22":23,"_24":25,"_26":27,"_28":29,"_30":-5,"_31":32,"_33":34,"_35":-5},"handle","rastitoz","name","omni-revenue-orchestrator","branchName","main","version","path","frontend","project",{"_36":257,"_13":14,"_38":258,"_51":-5,"_259":53,"_54":55,"_260":55,"_261":262,"_263":-5,"_264":265,"_266":123,"_267":76,"_268":-5,"_269":-5,"_270":34,"_58":271,"_272":273,"_274":275,"_276":277,"_278":-5,"_279":280,"_281":280,"_282":283,"_284":283,"_285":283,"_286":280,"_287":280,"_288":289,"_290":291,"_292":293,"_52":53},"tree",[106,107,108,109,110,111,112],"file",{"_36":103,"_13":19,"_67":70,"_69":-5,"_71":72,"_73":74,"_75":76,"_38":104,"_17":34,"_78":101,"_80":-5,"_82":53,"_83":-5,"_18":105},"contents",[61,62,63,64],"upstream",{"_36":37,"_38":39,"_40":41,"_13":16,"_42":43,"_17":44,"_45":46,"_47":48,"_49":50,"_51":-5,"_52":53,"_54":55,"_56":57,"_58":59,"_60":14},"pull","ahead",3,"behind",0,"envVars","id","f9455366-47d6-11f1-aeba-42b51c65c3df","createdAt",["D",1777912405533],"updatedAt",["D",1777912670090],"projectId","f93f9bba-47d6-11f1-aeba-42b51c65c3df",18,"forkedBranchId","961078ea-f528-11ef-aa68-569c3dd06744","forkedBranchVersion",88,"lockfileKey","1785171695560-esm.town_v_harantiti_omni-revenue-orchestrator@18-main","deletedAt","isOwned",false,"privacy","public","userHandle","harantiti","orgId","019df3d5-5949-77d9-81ed-9383f66ffa24","projectName",{"_36":97,"_13":98,"_67":99,"_69":70,"_71":72,"_73":74,"_75":76,"_38":100,"_17":34,"_78":101,"_80":-5,"_82":53,"_83":-5,"_18":102},{"_36":91,"_13":92,"_67":93,"_69":70,"_71":72,"_73":74,"_75":76,"_38":94,"_17":34,"_78":24,"_80":95,"_82":53,"_83":-5,"_18":96},{"_36":85,"_13":86,"_67":87,"_69":70,"_71":72,"_73":74,"_75":76,"_38":88,"_17":34,"_78":24,"_80":89,"_82":53,"_83":-5,"_18":90},{"_36":65,"_13":66,"_67":68,"_69":70,"_71":72,"_73":74,"_75":76,"_38":77,"_17":34,"_78":79,"_80":81,"_82":53,"_83":-5,"_18":84},"51e1f350-47df-11f1-8db4-42b51c65c3df","index.tsx","fileId","019df40d-10ba-777e-b50d-564a2e7c91a4","parentId","019df40d-10ba-777e-b50d-594050c8d796","branchId","51db919a-47df-11f1-8db4-42b51c65c3df","branchVersion",1,"latest",true,["D",1777915990125],"fileType","script","content","/** @jsxImportSource https://esm.sh/react@18.2.0 */\nimport { createRoot } from \"https://esm.sh/react-dom@18.2.0/client\";\nimport { App } from \"./components/App.tsx\";\n\nconst root = document.getElementById(\"root\");\nif (!root) {\n throw new Error(\"No root element found\");\n}\n\ncreateRoot(root).render();","deleted","label",[19,66],"51e1ed2e-47df-11f1-8db4-42b51c65c3df","index.html","019df40d-10ba-777e-b50d-51ced0494c0f",["D",1777915990125],"\n\n \n \n \n Omni-Revenue Orchestrator\n \n \n \n \n

\n \n \n \n",[19,86],"51e1ea5e-47df-11f1-8db4-42b51c65c3df","favicon.svg","019df40d-10ba-777e-b50d-4c7d032df0d8",["D",1777915990125],"\n",[19,92],"51e1e8f6-47df-11f1-8db4-42b51c65c3df","components","019df40d-10ba-777e-b50d-4b1a8a82b578",["D",1777915990125],"directory",[19,98],"51e1f7ce-47df-11f1-8db4-42b51c65c3df",["D",1777915990125],[19],{"_36":242,"_13":243,"_67":244,"_69":-5,"_71":72,"_73":74,"_75":76,"_38":245,"_17":34,"_78":101,"_80":-5,"_82":53,"_83":-5,"_118":246,"_18":247},{"_36":103,"_13":19,"_67":70,"_69":-5,"_71":72,"_73":74,"_75":76,"_38":207,"_17":34,"_78":101,"_80":-5,"_82":53,"_83":-5,"_118":208,"_18":209},{"_36":144,"_13":145,"_67":146,"_69":-5,"_71":72,"_73":74,"_75":76,"_38":147,"_17":34,"_78":101,"_80":-5,"_82":53,"_83":-5,"_118":148,"_18":149},{"_36":137,"_13":138,"_67":139,"_69":-5,"_71":72,"_73":74,"_75":76,"_38":140,"_17":34,"_78":24,"_80":141,"_82":53,"_83":-5,"_118":142,"_18":143},{"_36":130,"_13":131,"_67":132,"_69":-5,"_71":72,"_73":74,"_75":76,"_38":133,"_17":34,"_78":79,"_80":134,"_82":53,"_83":-5,"_118":135,"_18":136},{"_36":121,"_13":122,"_67":123,"_69":-5,"_71":72,"_73":124,"_75":76,"_38":125,"_17":74,"_78":126,"_80":127,"_82":53,"_83":-5,"_118":128,"_18":129},{"_36":113,"_13":114,"_67":115,"_69":-5,"_71":72,"_73":74,"_75":76,"_38":116,"_17":34,"_78":79,"_80":117,"_82":53,"_83":-5,"_118":119,"_18":120},"51e2cc80-47df-11f1-8db4-42b51c65c3df","types.ts","019df40d-10bb-731b-b553-52c2dce23d88",["D",1777915990125],"// ============================================================================\n// OMNI-REVENUE ORCHESTRATOR — DOMAIN TYPES\n// Strict state machine + row layout per system spec.\n// ============================================================================\n\n/**\n * Lead lifecycle state machine.\n * Transitions are strictly forward (except 5:ERROR which can be set from any).\n */\nexport const STATUS = {\n INGESTED: 0,\n ENRICHED: 1,\n DRAFTED: 2,\n REVIEWED: 3,\n DISPATCHED: 4,\n ERROR: 5,\n} as const;\n\nexport type StatusId = (typeof STATUS)[keyof typeof STATUS];\n\nexport const STATUS_LABEL: Record = {\n 0: \"INGESTED\",\n 1: \"ENRICHED\",\n 2: \"DRAFTED\",\n 3: \"REVIEWED\",\n 4: \"DISPATCHED\",\n 5: \"ERROR\",\n};\n\n/**\n * Sheet column layout (A..H), 0-indexed.\n * Mirrored as row order in IngestionEngine.appendRow.\n */\nexport const COL = {\n TIMESTAMP: 0, // A\n SOURCE: 1, // B\n STATUS_ID: 2, // C\n UID_HASH: 3, // D\n CONTACT_RAW: 4, // E\n CONTEXT_METADATA: 5, // F\n AI_PAYLOAD: 6, // G\n PRIORITY_SCORE: 7, // H\n} as const;\n\nexport interface Lead {\n rowIndex: number; // sheet row number (1-indexed; header is row 1)\n timestamp: string; // ISO\n source: string; // 'web', 'email', 'manual', etc.\n status_id: StatusId;\n uid_hash: string; // SHA-256 of `${contact_raw}|${source}`\n contact_raw: string; // email | phone | handle\n context_metadata: string; // free-text intent / niche keywords\n ai_payload: string; // generated draft (JSON or text)\n priority_score: number; // 0–100\n}\n\nexport interface IngestRequest {\n source: string;\n contact_raw: string;\n context_metadata?: string;\n priority_score?: number;\n}\n\n/** Parsed ai_payload contract. Stored serialized in column G. */\nexport interface AIPayload {\n draft: string; // outbound message body\n niche: string; // detected niche tag\n cta_link: string; // injected expert link\n rationale: string; // why this draft works\n generated_at: string; // ISO\n}\n\n/** Telegram callback action protocol: `${action}:${rowIndex}` */\nexport type CallbackAction = \"EXECUTE\" | \"REGEN\" | \"VIEW\";\n","children",[],[114],"87993ae4-47df-11f1-afc6-42b51c65c3df","index.ts","019df40d-10bb-731b-b553-4deb71aac3e0",4,["D",1777916080329],"http","// ============================================================================\n// OMNI-REVENUE ORCHESTRATOR — HTTP entrypoint.\n// Hono router + ADMIN_KEY gate + global error-boundary + Telegram webhook.\n//\n// V6.2 changes:\n// - ADMIN_KEY gate on `/`, `/api/leads`, `/admin/init`.\n// * 503 if ADMIN_KEY env var is missing.\n// * 401 if `?key=…` (or `x-admin-key` header) doesn't match.\n// - `/api/lead` and `/api/telegram` remain unauthenticated (public webhooks);\n// they have their own validation (spam shield + Telegram secret token).\n// - Hot-Path: pipeline.ingest() now triggers AI in the background.\n// ============================================================================\n\nimport { parseVal, serveFile } from \"https://esm.town/v/std/utils/index.ts\";\nimport { Hono, type Context, type Next } from \"npm:hono\";\n\nimport * as sheets from \"./services/sheets.ts\";\nimport * as pipeline from \"./services/pipeline.ts\";\nimport * as tg from \"./services/telegram.ts\";\nimport { serviceAccountEmail } from \"./services/auth.ts\";\nimport { TELEGRAM_ADMIN_CHAT_ID } from \"./config.ts\";\nimport { STATUS, STATUS_LABEL, type IngestRequest } from \"./types.ts\";\n\nconst app = new Hono();\n\n// ---------------------------------------------------------------------------\n// ADMIN_KEY gate\n// Returns 503 when the env var is unset (prevents accidental public exposure).\n// Returns 401 when the caller's key (header `x-admin-key` or `?key=`) is wrong.\n// ---------------------------------------------------------------------------\nasync function adminGate(c: Context, next: Next) {\n const expected = Deno.env.get(\"ADMIN_KEY\");\n if (!expected) {\n return c.json(\n { error: \"ADMIN_KEY env var is not set — admin surfaces are locked.\" },\n 503,\n );\n }\n const provided = c.req.header(\"x-admin-key\") ?? c.req.query(\"key\") ?? \"\";\n if (provided !== expected) {\n return c.json({ error: \"unauthorized\" }, 401);\n }\n await next();\n}\n\n// ---------------------------------------------------------------------------\n// Static / UI — gated.\n// ---------------------------------------------------------------------------\napp.get(\"/\", adminGate, () => serveFile(\"/frontend/index.html\"));\napp.get(\"/frontend/**/*\", adminGate, (c) => serveFile(c.req.path));\napp.get(\"/source\", (c) => c.redirect(parseVal().links.self.val)); // public: view code\n\n// ---------------------------------------------------------------------------\n// Dashboard data feed — gated.\n// ---------------------------------------------------------------------------\napp.get(\"/api/leads\", adminGate, async (c) => {\n const leads = await sheets.getRecentLeads(50);\n return c.json({\n leads,\n statusLabels: STATUS_LABEL,\n });\n});\n\n// ---------------------------------------------------------------------------\n// IngestionEngine — public webhook endpoint.\n// Spam shield runs inside pipeline.ingest(); junk is rejected with 422.\n// ---------------------------------------------------------------------------\napp.post(\"/api/lead\", async (c) => {\n const body = await c.req.json().catch(() => null) as IngestRequest | null;\n if (!body || typeof body.contact_raw !== \"string\" || typeof body.source !== \"string\") {\n return c.json({ error: \"contact_raw and source are required strings\" }, 400);\n }\n\n const result = await pipeline.ingest(body);\n\n if (result.blocked) {\n return c.json({ ok: false, blocked: true, reason: result.reason }, 422);\n }\n if (!result.lead) {\n return c.json({ error: \"ingest succeeded but row could not be re-fetched\" }, 502);\n }\n return c.json({\n ok: true,\n deduped: result.deduped,\n rowIndex: result.lead.rowIndex,\n uid_hash: result.lead.uid_hash,\n status_id: result.lead.status_id,\n hot_path: !result.deduped, // true ⇒ background AI was triggered\n }, result.deduped ? 200 : 201);\n});\n\n// ---------------------------------------------------------------------------\n// Telegram webhook — public, but validated via the bot secret token.\n// ---------------------------------------------------------------------------\napp.post(\"/api/telegram\", async (c) => {\n const sentSecret = c.req.header(\"x-telegram-bot-api-secret-token\");\n if (sentSecret !== tg.webhookSecret()) {\n return c.json({ error: \"unauthorized\" }, 401);\n }\n\n const update = await c.req.json().catch(() => null) as\n | { callback_query?: TgCallback; message?: TgMessage }\n | null;\n if (!update) return c.json({ ok: true });\n\n // Only the configured admin can issue C&C commands.\n if (update.callback_query) {\n const cb = update.callback_query;\n if (cb.from?.id !== TELEGRAM_ADMIN_CHAT_ID) {\n await tg.answerCallback(cb.id, \"unauthorized\");\n return c.json({ ok: true });\n }\n await handleCallback(cb);\n }\n\n return c.json({ ok: true });\n});\n\ninterface TgCallback {\n id: string;\n data?: string;\n from?: { id: number };\n message?: { chat: { id: number }; message_id: number };\n}\ninterface TgMessage {\n from?: { id: number };\n chat?: { id: number };\n text?: string;\n}\n\nasync function handleCallback(cb: TgCallback): Promise {\n const parsed = cb.data ? tg.parseCallback(cb.data) : null;\n if (!parsed || !cb.message) {\n await tg.answerCallback(cb.id, \"bad payload\");\n return;\n }\n\n const { action, rowIndex } = parsed;\n const chatId = cb.message.chat.id;\n const msgId = cb.message.message_id;\n\n const lead = await sheets.getLeadByRow(rowIndex);\n if (!lead) {\n await tg.answerCallback(cb.id, \"row not found\");\n return;\n }\n\n switch (action) {\n case \"VIEW\": {\n const dump = [\n `*Row #${lead.rowIndex} — RAW*`,\n \"```\",\n JSON.stringify(lead, null, 2).slice(0, 3500),\n \"```\",\n ].join(\"\\n\");\n await tg.alertAdmin(dump);\n await tg.answerCallback(cb.id, \"raw posted\");\n return;\n }\n case \"REGEN\": {\n await tg.answerCallback(cb.id, \"re-generating…\");\n // Force regen by resetting status below DRAFTED.\n await sheets.updateStatus(lead.rowIndex, STATUS.INGESTED);\n const refreshed = { ...lead, status_id: STATUS.INGESTED };\n const drafted = await pipeline.enrichAndDraft(refreshed);\n await tg.editCard(\n chatId,\n msgId,\n `🔄 *Re-generated #${lead.rowIndex}*\\nNew draft sent below.`,\n false,\n );\n await pipeline.presentForReview(drafted);\n return;\n }\n case \"EXECUTE\": {\n await sheets.updateStatus(lead.rowIndex, STATUS.REVIEWED);\n await pipeline.dispatch(lead.rowIndex);\n await tg.editCard(\n chatId,\n msgId,\n `✅ *Dispatched #${lead.rowIndex}* — \\`${lead.contact_raw}\\``,\n false,\n );\n await tg.answerCallback(cb.id, \"dispatched\");\n return;\n }\n }\n}\n\n// ---------------------------------------------------------------------------\n// Admin / init — gated.\n// ---------------------------------------------------------------------------\napp.get(\"/admin/init\", adminGate, async (c) => {\n const url = new URL(c.req.url);\n const webhookUrl = `${url.origin}/api/telegram`;\n\n const checks: Record = {};\n\n // Service Account handshake.\n try {\n checks.service_account = serviceAccountEmail();\n const sample = await sheets.getRecentLeads(1);\n checks.sheet_access = \"ok\";\n checks.sample_row_count = sample.length;\n } catch (e) {\n checks.service_account_error = (e as Error).message;\n }\n\n // Telegram webhook.\n try {\n await tg.setWebhook(webhookUrl, tg.webhookSecret());\n checks.telegram_webhook = webhookUrl;\n } catch (e) {\n checks.telegram_webhook_error = (e as Error).message;\n }\n\n return c.json({ ok: true, checks });\n});\n\n// ---------------------------------------------------------------------------\n// Global error-boundary — 429 (OpenAI) and 403 (Google) get Telegram alerts.\n// ---------------------------------------------------------------------------\napp.onError((err, c) => {\n const e = err as Error & { status?: number; provider?: string };\n const status = e.status ?? 500;\n const provider = e.provider ?? \"unknown\";\n\n if (status === 429 && provider === \"openai\") {\n tg.alertAdmin(`OpenAI 429 (rate-limit) — ${e.message}`).catch(() => {});\n } else if (status === 403 && provider === \"google\") {\n tg.alertAdmin(`Google 403 (auth/quota) — ${e.message}`).catch(() => {});\n } else if (status >= 500) {\n tg.alertAdmin(`Server ${status} — ${e.message}`).catch(() => {});\n }\n\n console.error(\"[onError]\", provider, status, e.message);\n return c.json(\n { error: e.message, status, provider },\n status >= 400 && status < 600 ? status as 500 : 500,\n );\n});\n\nexport default app.fetch;\n",[],[122],"51e29cc4-47df-11f1-8db4-42b51c65c3df","config.ts","019df40d-10bb-731b-b553-481a213125f1",["D",1777915990125],"// ============================================================================\n// OMNI-REVENUE ORCHESTRATOR — RUNTIME CONFIG\n// Centralizes spec-mandated constants. Edit here to retarget the system.\n// ============================================================================\n\nexport const SHEET_ID = \"1YRlfO_L1bsyaPZPvenQfnpkZVcjUEYdIiQXo5BjfHcw\";\n\n/** Tab name within the spreadsheet. Defaults to first/only tab \"Sheet1\". */\nexport const SHEET_TAB = \"Sheet1\";\n\n/** Header row + data range used by the sweep. Spec: A2:H35. */\nexport const SWEEP_RANGE = `${SHEET_TAB}!A2:H35`;\n\n/** Full data range for dashboard (last 50 rows). */\nexport const FULL_RANGE = `${SHEET_TAB}!A2:H1000`;\n\n/** Append target — Google's API expands automatically. */\nexport const APPEND_RANGE = `${SHEET_TAB}!A:H`;\n\n/** Telegram admin chat id authorized to receive cards & issue callbacks. */\nexport const TELEGRAM_ADMIN_CHAT_ID = 466679766;\n\n/** Niche → CTA injection map. Order matters (first match wins). */\nexport const NICHE_RULES: ReadonlyArray<{ pattern: RegExp; niche: string; cta: string }> = [\n {\n pattern: /seo/i,\n niche: \"seo\",\n cta: \"https://your-expert-link.com/seo-audit\",\n },\n {\n pattern: /growth|scaling/i,\n niche: \"growth\",\n cta: \"https://your-expert-link.com/vsl\",\n },\n];\n\n/** Default fallback CTA when no niche regex matches. */\nexport const DEFAULT_CTA = \"https://your-expert-link.com/discovery\";\n\n/** OpenAI model id. */\nexport const LLM_MODEL = \"gpt-4o\";\n",[],[131],"51e2703c-47df-11f1-8db4-42b51c65c3df","README.md","019df40d-10bb-731b-b553-467b8ce55709",["D",1777915990125],"# Omni-Revenue Orchestrator (v3.0-CORE)\n\nEvent-driven CRM triage system. Hono middleware + React admin view + sequential pipeline (Ingest → Enrich → Draft → Review → Dispatch). Persistence in Google Sheets. Command & control via Telegram inline cards.\n\n> **Status:** code is deployed; you must provision env vars below before any\n> pipeline call will succeed. The `/` dashboard renders without secrets but\n> shows an error banner until `GOOGLE_JSON` is set.\n\n## Architecture\n\n```mermaid\nflowchart LR\n subgraph Client\n Browser\n Webhook[\"Lead source
(form, scraper, etc.)\"]\n Admin[\"Telegram
admin chat\"]\n end\n\n subgraph \"HTTP (index.ts)\"\n H[\"Hono
+ error-boundary\"]\n UI[\"GET /
React dashboard\"]\n Ing[\"POST /api/lead\"]\n Tg[\"POST /api/telegram\"]\n Init[\"GET /admin/init\"]\n Feed[\"GET /api/leads\"]\n end\n\n subgraph Services\n Auth[\"auth.ts
JWT → Google\"]\n Sheets[\"sheets.ts\"]\n LLM[\"llm.ts
GPT-4o + niche map\"]\n TgSvc[\"telegram.ts\"]\n Pipe[\"pipeline.ts\"]\n Idem[\"idempotency.ts
SHA-256\"]\n end\n\n subgraph Cron\n Sweep[\"cron/sweep.ts
15m · A2:H35\"]\n end\n\n subgraph External\n GS[(\"Google Sheets
1YRlfO_…\")]\n OAI[(\"OpenAI\")]\n TGAPI[(\"Telegram Bot API\")]\n end\n\n Browser --> UI\n UI --> Feed --> Sheets\n Webhook --> Ing --> Pipe\n Pipe --> Idem\n Pipe --> Sheets --> Auth\n Pipe --> LLM --> OAI\n Pipe --> TgSvc --> TGAPI --> Admin\n Admin -->|callback| Tg --> Pipe\n Sweep --> Sheets\n Sweep --> LLM\n Sweep --> TgSvc\n Init --> Auth\n Init --> TgSvc\n Auth --> GS\n Sheets --> GS\n```\n\n## Lifecycle / state machine\n\n| status_id | label | written by |\n| --------- | ----------- | ---------------------------- |\n| `0` | INGESTED | `POST /api/lead` |\n| `1` | ENRICHED | (collapsed into DRAFTED) |\n| `2` | DRAFTED | `pipeline.enrichAndDraft` |\n| `3` | REVIEWED | Telegram `✅ EXECUTE` button |\n| `4` | DISPATCHED | `pipeline.dispatch` |\n| `5` | ERROR | any failure path |\n\n## Sheet layout (cols A..H)\n\n`timestamp | source | status_id | uid_hash | contact_raw | context_metadata | ai_payload | priority_score`\n\n`uid_hash` = `SHA-256(\"${contact_raw}|${source}\")` — used as the idempotency key.\n\n## File map\n\n```\nindex.ts ← HTTP routes + global error-boundary\nconfig.ts ← SHEET_ID, niche rules, admin chat id, model\ntypes.ts ← STATUS enum, COL enum, Lead/AIPayload/Callback types\nservices/\n auth.ts ← Google service-account JWT (RS256, in-mem cache)\n sheets.ts ← typed Sheets v4 wrapper (append/read/update)\n idempotency.ts ← SHA-256 uid_hash\n llm.ts ← GPT-4o \"Elite Conversion\" + niche map\n telegram.ts ← bot client, C&C cards, callback parser\n pipeline.ts ← lifecycle orchestrator (ingest/draft/dispatch)\ncron/\n sweep.ts ← 15-min reclamation task on A2:H35\nfrontend/\n index.html ← shell (Twind)\n index.tsx ← React entrypoint\n components/\n App.tsx ← layout + status strip + auto-refresh\n LeadsTable.tsx ← last 50 rows table w/ expandable drafts\n```\n\n## Required environment variables\n\n| Key | What |\n| ----------------- | ----------------------------------------------------------------------------------------- |\n| `GOOGLE_JSON` | Full service-account JSON (paste the entire file content). Must have edit on the sheet. |\n| `OPENAI_API_KEY` | OpenAI key with access to `gpt-4o`. |\n| `TELEGRAM_TOKEN` | Bot token from @BotFather. Used for both webhook auth (secret = part after `:`) and API. |\n\n### Google Sheets prerequisite\n\n1. Share sheet `1YRlfO_L1bsyaPZPvenQfnpkZVcjUEYdIiQXo5BjfHcw` with the\n service-account email (Editor).\n2. Sheet must have a header row 1 with the eight columns above (anything works\n as labels — the code only reads `A2:H…`).\n\n## Bring-up sequence\n\n1. Set the three env vars above.\n2. Hit `GET /admin/init` once — performs:\n - Service-account handshake (verifies sheet access, returns sample row count)\n - `setWebhook` against `/api/telegram` with the derived secret token\n3. POST a test lead:\n\n ```bash\n curl -X POST https:///api/lead \\\n -H 'Content-Type: application/json' \\\n -d '{\n \"source\": \"manual\",\n \"contact_raw\": \"ada@example.com\",\n \"context_metadata\": \"Wants help with SEO for SaaS landing pages\",\n \"priority_score\": 80\n }'\n ```\n\n You should see:\n - row 2 (or next) appended to the sheet with `status_id=0`\n - Telegram alert `📥 INGESTED …` to admin\n4. Wait ≤15 min for the sweep — or manually run `cron/sweep.ts` from the\n editor's \"Run\" button. The row will advance to `status_id=2` (DRAFTED) and\n the admin gets a card with `[✅ EXECUTE] [🔄 RE-GENERATE] [📊 VIEW RAW]`.\n\n## Niche-mapping logic\n\nDefined in `config.ts → NICHE_RULES`. First-match-wins regex over\n`context_metadata`:\n\n| pattern | niche | injected CTA |\n| -------------------- | -------- | --------------------------------------------- |\n| `/seo/i` | seo | `https://your-expert-link.com/seo-audit` |\n| `/growth\\|scaling/i` | growth | `https://your-expert-link.com/vsl` |\n| (fallback) | general | `https://your-expert-link.com/discovery` |\n\nThe LLM is instructed to use `{{CTA_LINK}}` as a placeholder; we substitute\npost-generation so the niche map is authoritative.\n\n## Error boundary\n\nEvery Hono route is wrapped by `app.onError`. Errors thrown from\n`services/sheets.ts` carry `provider=\"google\"` + `status`; `services/llm.ts`\ncarry `provider=\"openai\"`. The boundary fires `tg.alertAdmin(...)` for the\ntwo spec-mandated codes:\n\n- `429 + openai` → \"OpenAI 429 (rate-limit) — …\"\n- `403 + google` → \"Google 403 (auth/quota) — …\"\n\n…plus a generic alert for any 5xx.\n\n## Telegram C&C protocol\n\nCallback data format: `${ACTION}:${rowIndex}` where ACTION ∈\n`{EXECUTE, REGEN, VIEW}`. Only `chat_id === 466679766` is honored; any other\nsender gets an \"unauthorized\" toast.\n\n## Local dev / customization\n\n- Retarget the sheet → edit `SHEET_ID` in `config.ts`.\n- Add a niche → push to `NICHE_RULES`.\n- Wire a real outbound channel → fill in `pipeline.dispatch()`.\n- Sweep window → edit `SWEEP_RANGE` in `config.ts` and the interval delay on\n `cron/sweep.ts` (free tier minimum 15 min).\n\n## View source\n\n[View source on Val Town](/source)\n",[],[138],"51e26eac-47df-11f1-8db4-42b51c65c3df","services","019df40d-10bb-731b-b553-422a2b046702",["D",1777915990125],[150,151,152,153,154,155,156],[145],{"_36":200,"_13":201,"_67":202,"_69":146,"_71":72,"_73":74,"_75":76,"_38":203,"_17":34,"_78":79,"_80":204,"_82":53,"_83":-5,"_118":205,"_18":206},{"_36":193,"_13":194,"_67":195,"_69":146,"_71":72,"_73":74,"_75":76,"_38":196,"_17":34,"_78":79,"_80":197,"_82":53,"_83":-5,"_118":198,"_18":199},{"_36":186,"_13":187,"_67":188,"_69":146,"_71":72,"_73":74,"_75":76,"_38":189,"_17":34,"_78":79,"_80":190,"_82":53,"_83":-5,"_118":191,"_18":192},{"_36":179,"_13":180,"_67":181,"_69":146,"_71":72,"_73":32,"_75":76,"_38":182,"_17":74,"_78":79,"_80":183,"_82":53,"_83":-5,"_118":184,"_18":185},{"_36":172,"_13":173,"_67":174,"_69":146,"_71":72,"_73":74,"_75":76,"_38":175,"_17":34,"_78":79,"_80":176,"_82":53,"_83":-5,"_118":177,"_18":178},{"_36":164,"_13":165,"_67":166,"_69":146,"_71":72,"_73":167,"_75":76,"_38":168,"_17":34,"_78":79,"_80":169,"_82":53,"_83":-5,"_118":170,"_18":171},{"_36":157,"_13":158,"_67":159,"_69":146,"_71":72,"_73":74,"_75":76,"_38":160,"_17":34,"_78":79,"_80":161,"_82":53,"_83":-5,"_118":162,"_18":163},"51e25570-47df-11f1-8db4-42b51c65c3df","telegram.ts","019df40d-10bb-731b-b553-3eb486b85922",["D",1777915990125],"// ============================================================================\n// TelegramService — thin client over the Bot API.\n// - Sends C&C cards with inline callback buttons.\n// - Receives webhook updates and dispatches callback_query events.\n// - Surfaces error-boundary alerts.\n// ============================================================================\n\nimport { TELEGRAM_ADMIN_CHAT_ID } from \"../config.ts\";\nimport type { CallbackAction, Lead } from \"../types.ts\";\nimport { STATUS_LABEL } from \"../types.ts\";\n\nconst TG_API = \"https://api.telegram.org\";\n\nfunction token(): string {\n const t = Deno.env.get(\"TELEGRAM_TOKEN\");\n if (!t) throw new Error(\"TELEGRAM_TOKEN env var is not set\");\n return t;\n}\n\nasync function tgcall(method: string, body: unknown): Promise {\n const resp = await fetch(`${TG_API}/bot${token()}/${method}`, {\n method: \"POST\",\n headers: { \"Content-Type\": \"application/json\" },\n body: JSON.stringify(body),\n });\n if (!resp.ok) {\n const text = await resp.text();\n throw new Error(`Telegram ${method} ${resp.status}: ${text}`);\n }\n return await resp.json() as T;\n}\n\n/** Plain-text alert to admin. Used by error-boundary. */\nexport async function alertAdmin(message: string): Promise {\n try {\n await tgcall(\"sendMessage\", {\n chat_id: TELEGRAM_ADMIN_CHAT_ID,\n text: `🚨 ${message}`,\n parse_mode: \"Markdown\",\n });\n } catch (e) {\n // Last-resort logging — do not throw out of the alerter.\n console.error(\"alertAdmin failed:\", e);\n }\n}\n\n/** Build inline keyboard for a draft. */\nfunction buildCard(lead: Lead) {\n const lines = [\n `🎯 *Lead #${lead.rowIndex}* — _${STATUS_LABEL[lead.status_id]}_`,\n `📡 source: \\`${lead.source}\\``,\n `📞 contact: \\`${escapeMd(lead.contact_raw)}\\``,\n `🧠 context: ${escapeMd(lead.context_metadata).slice(0, 200)}`,\n `⭐ priority: *${lead.priority_score}*`,\n \"\",\n \"*Draft:*\",\n \"```\",\n truncate(lead.ai_payload, 1000),\n \"```\",\n ];\n return {\n text: lines.join(\"\\n\"),\n reply_markup: {\n inline_keyboard: [[\n { text: \"✅ EXECUTE\", callback_data: `EXECUTE:${lead.rowIndex}` },\n { text: \"🔄 RE-GENERATE\", callback_data: `REGEN:${lead.rowIndex}` },\n { text: \"📊 VIEW RAW\", callback_data: `VIEW:${lead.rowIndex}` },\n ]],\n },\n };\n}\n\n/** Lightweight Markdown escaper for Telegram's MarkdownV1 mode. */\nfunction escapeMd(s: string): string {\n return (s ?? \"\").replace(/[`*_]/g, (c) => `\\\\${c}`);\n}\n\nfunction truncate(s: string, n: number): string {\n if (!s) return \"(empty)\";\n return s.length > n ? s.slice(0, n) + \"…\" : s;\n}\n\n/** Send a fresh card for a lead to the admin. */\nexport async function sendCard(lead: Lead): Promise {\n const card = buildCard(lead);\n await tgcall(\"sendMessage\", {\n chat_id: TELEGRAM_ADMIN_CHAT_ID,\n text: card.text,\n parse_mode: \"Markdown\",\n reply_markup: card.reply_markup,\n });\n}\n\n/** Edit an existing card after a status transition (e.g. EXECUTE -> dispatched). */\nexport async function editCard(\n chatId: number,\n messageId: number,\n text: string,\n showButtons = false,\n lead?: Lead,\n): Promise {\n await tgcall(\"editMessageText\", {\n chat_id: chatId,\n message_id: messageId,\n text,\n parse_mode: \"Markdown\",\n reply_markup: showButtons && lead ? buildCard(lead).reply_markup : { inline_keyboard: [] },\n });\n}\n\n/** Acknowledge a callback_query so Telegram clears the loading spinner. */\nexport async function answerCallback(callbackId: string, text?: string): Promise {\n await tgcall(\"answerCallbackQuery\", {\n callback_query_id: callbackId,\n text: text ?? \"\",\n });\n}\n\n/** Set webhook to a given URL with a shared secret. */\nexport async function setWebhook(url: string, secretToken: string): Promise {\n await tgcall(\"setWebhook\", {\n url,\n secret_token: secretToken,\n allowed_updates: [\"message\", \"callback_query\"],\n });\n}\n\n/** Decode our `${ACTION}:${rowIndex}` callback protocol. */\nexport function parseCallback(data: string): { action: CallbackAction; rowIndex: number } | null {\n const [action, raw] = data.split(\":\");\n const row = Number(raw);\n if (!Number.isFinite(row)) return null;\n if (action !== \"EXECUTE\" && action !== \"REGEN\" && action !== \"VIEW\") return null;\n return { action, rowIndex: row };\n}\n\n/** Stable secret derived from TELEGRAM_TOKEN — see std/telegramBotStarter pattern. */\nexport function webhookSecret(): string {\n return token().split(\":\")[1];\n}\n",[],[145,158],"61160424-47df-11f1-942c-42b51c65c3df","spam.ts","61160528-47df-11f1-942c-42b51c65c3df",2,["D",1777916015719],"// ============================================================================\n// SpamShield — pre-AI filter for junk leads.\n// Cheap regex / heuristic checks. No network, no LLM, deterministic.\n// pipeline.ingest() short-circuits on spam=true and never touches the sheet.\n// ============================================================================\n\nimport type { IngestRequest } from \"../types.ts\";\n\n/** Disposable / throwaway email domains. Non-exhaustive but covers the 80%. */\nconst DISPOSABLE_EMAIL_DOMAINS = new Set([\n \"mailinator.com\",\n \"guerrillamail.com\",\n \"guerrillamail.info\",\n \"guerrillamail.biz\",\n \"sharklasers.com\",\n \"10minutemail.com\",\n \"10minutemail.net\",\n \"tempmail.com\",\n \"temp-mail.org\",\n \"temp-mail.io\",\n \"throwawaymail.com\",\n \"yopmail.com\",\n \"trashmail.com\",\n \"trashmail.de\",\n \"getnada.com\",\n \"nada.email\",\n \"fakeinbox.com\",\n \"maildrop.cc\",\n \"dispostable.com\",\n \"mintemail.com\",\n \"mohmal.com\",\n \"tempinbox.com\",\n \"spamgourmet.com\",\n \"mytrashmail.com\",\n \"tempmailaddress.com\",\n \"moakt.com\",\n \"discard.email\",\n \"emailondeck.com\",\n]);\n\n/** TLDs heavily associated with bot/scam traffic. */\nconst BLOCKED_TLDS = new Set([\n \"xyz\",\n \"top\",\n \"click\",\n \"loan\",\n \"win\",\n \"men\",\n \"review\",\n \"country\",\n \"stream\",\n \"gdn\",\n \"racing\",\n \"download\",\n \"cricket\",\n \"science\",\n \"party\",\n \"trade\",\n \"bid\",\n \"kim\",\n \"rest\",\n \"tk\",\n \"ml\",\n \"ga\",\n \"cf\",\n]);\n\nconst EMAIL_RE = /^[^\\s@]+@([^\\s@]+\\.[^\\s@]+)$/;\n\nexport interface SpamVerdict {\n spam: boolean;\n reason?: string;\n}\n\n/** Run the shield. Order matters — cheapest checks first. */\nexport function checkSpam(req: IngestRequest): SpamVerdict {\n const contact = (req.contact_raw ?? \"\").trim();\n const context = (req.context_metadata ?? \"\").trim();\n const source = (req.source ?? \"\").trim();\n\n // 1. Source / contact length sanity.\n if (source.length === 0 || source.length > 64) {\n return { spam: true, reason: \"invalid source length\" };\n }\n if (contact.length < 4) {\n return { spam: true, reason: \"contact_raw too short\" };\n }\n if (contact.length > 256) {\n return { spam: true, reason: \"contact_raw too long\" };\n }\n\n // 2. Repetitive / keyboard-mash patterns in contact.\n if (/(.)\\1{5,}/.test(contact)) {\n return { spam: true, reason: \"repetitive characters in contact\" };\n }\n if (/^(asdf|qwer|zxcv|1234|abcd){2,}/i.test(contact)) {\n return { spam: true, reason: \"keyboard-mash pattern in contact\" };\n }\n\n // 3. Email-shaped contacts: domain checks.\n const m = contact.match(EMAIL_RE);\n if (m) {\n const domain = m[1].toLowerCase();\n const tld = domain.split(\".\").pop() ?? \"\";\n\n if (DISPOSABLE_EMAIL_DOMAINS.has(domain)) {\n return { spam: true, reason: `disposable email domain: ${domain}` };\n }\n if (BLOCKED_TLDS.has(tld)) {\n return { spam: true, reason: `blocked TLD: .${tld}` };\n }\n // Long all-consonant local-parts = machine-generated.\n const local = contact.split(\"@\")[0];\n if (local.length > 30 && /^[a-z0-9]+$/i.test(local) && !/[aeiou]/i.test(local)) {\n return { spam: true, reason: \"machine-generated email local-part\" };\n }\n }\n\n // 4. Repetitive / scammy context.\n if (context.length > 0) {\n if (/(.)\\1{10,}/.test(context)) {\n return { spam: true, reason: \"repetitive characters in context\" };\n }\n // Classic 419 / scam-template combos.\n if (\n /dear (sir|madam|friend)/i.test(context) &&\n /(bitcoin|crypto|loan|investment|inheritance|funds)/i.test(context)\n ) {\n return { spam: true, reason: \"classic scam template in context\" };\n }\n // Many URLs in context = link-spam.\n const urlCount = (context.match(/https?:\\/\\//gi) ?? []).length;\n if (urlCount >= 3) {\n return { spam: true, reason: `${urlCount} URLs in context (link-spam)` };\n }\n }\n\n return { spam: false };\n}\n",[],[145,165],"51e23b44-47df-11f1-8db4-42b51c65c3df","sheets.ts","019df40d-10bb-731b-b553-3a0854314919",["D",1777915990125],"// ============================================================================\n// SheetsService — typed wrapper around Google Sheets v4 REST.\n// All requests go through getAccessToken(); on 403 we surface to error boundary.\n// ============================================================================\n\nimport { getAccessToken } from \"./auth.ts\";\nimport {\n APPEND_RANGE,\n FULL_RANGE,\n SHEET_ID,\n SHEET_TAB,\n SWEEP_RANGE,\n} from \"../config.ts\";\nimport { COL, type Lead, STATUS, type StatusId } from \"../types.ts\";\n\nconst BASE = `https://sheets.googleapis.com/v4/spreadsheets/${SHEET_ID}`;\n\nasync function gfetch(url: string, init: RequestInit = {}): Promise {\n const token = await getAccessToken();\n const headers = new Headers(init.headers);\n headers.set(\"Authorization\", `Bearer ${token}`);\n headers.set(\"Content-Type\", \"application/json\");\n const resp = await fetch(url, { ...init, headers });\n if (!resp.ok) {\n const body = await resp.text();\n // Re-throw with status code preserved so the error-boundary middleware\n // can detect 403 and route an alert through Telegram.\n const err = new Error(`Sheets API ${resp.status}: ${body}`) as Error & {\n status?: number;\n provider?: string;\n };\n err.status = resp.status;\n err.provider = \"google\";\n throw err;\n }\n return resp;\n}\n\n/** Coerce a sheet row (string[]) into a strongly-typed Lead. */\nfunction rowToLead(row: string[], rowIndex: number): Lead {\n const safe = (i: number) => row[i] ?? \"\";\n const status = Number(safe(COL.STATUS_ID));\n return {\n rowIndex,\n timestamp: safe(COL.TIMESTAMP),\n source: safe(COL.SOURCE),\n status_id: (Number.isFinite(status) ? status : STATUS.ERROR) as StatusId,\n uid_hash: safe(COL.UID_HASH),\n contact_raw: safe(COL.CONTACT_RAW),\n context_metadata: safe(COL.CONTEXT_METADATA),\n ai_payload: safe(COL.AI_PAYLOAD),\n priority_score: Number(safe(COL.PRIORITY_SCORE)) || 0,\n };\n}\n\n/** Append a new lead row in the canonical column order. */\nexport async function appendRow(lead: Omit): Promise {\n const values = [\n lead.timestamp,\n lead.source,\n String(lead.status_id),\n lead.uid_hash,\n lead.contact_raw,\n lead.context_metadata,\n lead.ai_payload,\n String(lead.priority_score),\n ];\n await gfetch(\n `${BASE}/values/${encodeURIComponent(APPEND_RANGE)}:append?valueInputOption=RAW&insertDataOption=INSERT_ROWS`,\n {\n method: \"POST\",\n body: JSON.stringify({ values: [values] }),\n },\n );\n}\n\n/** Pull the sweep range (A2:H35) and return parsed leads. */\nexport async function getSweepRows(): Promise {\n const resp = await gfetch(\n `${BASE}/values/${encodeURIComponent(SWEEP_RANGE)}?majorDimension=ROWS`,\n );\n const json = await resp.json() as { values?: string[][] };\n return (json.values ?? []).map((row, i) => rowToLead(row, i + 2));\n}\n\n/** Pull the full range for the dashboard (last 50 entries returned). */\nexport async function getRecentLeads(limit = 50): Promise {\n const resp = await gfetch(\n `${BASE}/values/${encodeURIComponent(FULL_RANGE)}?majorDimension=ROWS`,\n );\n const json = await resp.json() as { values?: string[][] };\n const all = (json.values ?? []).map((row, i) => rowToLead(row, i + 2));\n return all.slice(-limit).reverse();\n}\n\n/** Find a lead by its uid_hash (idempotency key). */\nexport async function findByUidHash(uid: string): Promise {\n // Cheap implementation: scan recent. For production scale swap to a\n // dedicated index sheet or sqlite mirror.\n const resp = await gfetch(\n `${BASE}/values/${encodeURIComponent(`${SHEET_TAB}!A2:H10000`)}?majorDimension=ROWS`,\n );\n const json = await resp.json() as { values?: string[][] };\n const rows = json.values ?? [];\n for (let i = 0; i < rows.length; i++) {\n if (rows[i][COL.UID_HASH] === uid) return rowToLead(rows[i], i + 2);\n }\n return null;\n}\n\n/** Get a single lead by row number. */\nexport async function getLeadByRow(rowIndex: number): Promise {\n const range = `${SHEET_TAB}!A${rowIndex}:H${rowIndex}`;\n const resp = await gfetch(\n `${BASE}/values/${encodeURIComponent(range)}?majorDimension=ROWS`,\n );\n const json = await resp.json() as { values?: string[][] };\n const row = json.values?.[0];\n if (!row) return null;\n return rowToLead(row, rowIndex);\n}\n\n/** Patch a single cell in a row. Used to mutate status_id and ai_payload. */\nexport async function updateCell(\n rowIndex: number,\n col: number,\n value: string,\n): Promise {\n const colLetter = String.fromCharCode(65 + col); // A, B, ..., H\n const range = `${SHEET_TAB}!${colLetter}${rowIndex}:${colLetter}${rowIndex}`;\n await gfetch(\n `${BASE}/values/${encodeURIComponent(range)}?valueInputOption=RAW`,\n {\n method: \"PUT\",\n body: JSON.stringify({ values: [[value]] }),\n },\n );\n}\n\nexport async function updateStatus(rowIndex: number, status: StatusId): Promise {\n await updateCell(rowIndex, COL.STATUS_ID, String(status));\n}\n\nexport async function updateAIPayload(rowIndex: number, payload: string): Promise {\n await updateCell(rowIndex, COL.AI_PAYLOAD, payload);\n}\n",[],[145,173],"718379d6-47df-11f1-afc6-42b51c65c3df","pipeline.ts","019df40d-10bb-731b-b553-34dd2f808931",["D",1777916043277],"// ============================================================================\n// Pipeline — orchestrates the lead lifecycle stage transitions.\n// INGESTED -> ENRICHED -> DRAFTED -> REVIEWED -> DISPATCHED\n// Each transition is idempotent (re-running on a row in a higher state is a noop).\n//\n// V6.2: Hot-Path enabled. After a successful sheet append, we kick off\n// enrichAndDraft() in the background so the admin gets the strategic card\n// within seconds instead of waiting for the 15-min cron sweep. The sweep\n// remains as a safety net for failures.\n// ============================================================================\n\nimport * as sheets from \"./sheets.ts\";\nimport * as tg from \"./telegram.ts\";\nimport { draftFor } from \"./llm.ts\";\nimport { uidHash } from \"./idempotency.ts\";\nimport { checkSpam } from \"./spam.ts\";\nimport { COL, type IngestRequest, type Lead, STATUS } from \"../types.ts\";\n\n/**\n * Step 0/1 — Ingestion.\n * - SpamShield pre-filter (rejects junk before any I/O).\n * - SHA-256 idempotency check.\n * - Concurrent sheet append + admin notification.\n * - Hot-Path: triggers enrichAndDraft() in the background, non-blocking.\n *\n * Returns { lead, deduped, blocked } — `blocked` is true when SpamShield rejected.\n */\nexport async function ingest(\n req: IngestRequest,\n): Promise<{ lead: Lead | null; deduped: boolean; blocked: boolean; reason?: string }> {\n // 0. Spam shield — never touches sheet/AI/Telegram on rejection.\n const verdict = checkSpam(req);\n if (verdict.spam) {\n console.warn(\"[ingest] spam blocked:\", verdict.reason, \"contact=\", req.contact_raw);\n return { lead: null, deduped: false, blocked: true, reason: verdict.reason };\n }\n\n // 1. Idempotency.\n const uid = await uidHash(req.contact_raw, req.source);\n const existing = await sheets.findByUidHash(uid);\n if (existing) return { lead: existing, deduped: true, blocked: false };\n\n const skeleton: Omit = {\n timestamp: new Date().toISOString(),\n source: req.source,\n status_id: STATUS.INGESTED,\n uid_hash: uid,\n contact_raw: req.contact_raw,\n context_metadata: req.context_metadata ?? \"\",\n ai_payload: \"\",\n priority_score: req.priority_score ?? 0,\n };\n\n // Concurrent fan-out: sheet log + admin \"ingested\" alert.\n const results = await Promise.allSettled([\n sheets.appendRow(skeleton),\n tg.alertAdmin(\n `📥 *INGESTED*\\nsource: \\`${req.source}\\`\\ncontact: \\`${req.contact_raw}\\`\\npriority: *${skeleton.priority_score}*`,\n ),\n ]);\n\n const sheetResult = results[0];\n if (sheetResult.status === \"rejected\") throw sheetResult.reason;\n\n // Re-fetch to obtain assigned rowIndex.\n const created = await sheets.findByUidHash(uid);\n\n // 2. HOT-PATH — fire-and-forget background AI analysis.\n // On Val Town we just don't await; the runtime keeps the request alive.\n // Errors are caught locally so they don't propagate to the HTTP caller.\n if (created) {\n runHotPath(created).catch((e) => {\n console.error(\"[hot-path] background failure:\", (e as Error).message);\n });\n }\n\n return { lead: created, deduped: false, blocked: false };\n}\n\n/** Background task: enrich + present-for-review. Errors are surfaced to admin. */\nasync function runHotPath(lead: Lead): Promise {\n try {\n const drafted = await enrichAndDraft(lead);\n await presentForReview(drafted);\n } catch (e) {\n const err = e as Error & { status?: number; provider?: string };\n console.error(`[hot-path] row ${lead.rowIndex} failed:`, err.message);\n await markError(lead.rowIndex, err.message);\n await tg.alertAdmin(\n `Hot-path failed on row ${lead.rowIndex}: ${err.provider ?? \"\"} ${err.status ?? \"\"} ${err.message}`,\n ).catch(() => {});\n }\n}\n\n/**\n * Step 2/3 — Enrich + Draft.\n * Generates an AIPayload, writes it back, advances status to DRAFTED.\n * (We collapse ENRICHED -> DRAFTED: the LLM call is the enrichment.)\n */\nexport async function enrichAndDraft(lead: Lead): Promise {\n if (lead.status_id >= STATUS.DRAFTED) return lead;\n const payload = await draftFor(lead);\n const serialized = JSON.stringify(payload);\n await sheets.updateAIPayload(lead.rowIndex, serialized);\n await sheets.updateStatus(lead.rowIndex, STATUS.DRAFTED);\n return { ...lead, ai_payload: serialized, status_id: STATUS.DRAFTED };\n}\n\n/**\n * Step 4 — Send a C&C card to the admin so they can REVIEW/EXECUTE.\n * Marks the lead as DRAFTED; transitions to REVIEWED happen on button press.\n */\nexport async function presentForReview(lead: Lead): Promise {\n await tg.sendCard(lead);\n}\n\n/**\n * Step 5 — Mark as DISPATCHED. The actual send-out (email/sms/etc) is\n * stubbed here — wire to your outbound transport of choice.\n */\nexport async function dispatch(rowIndex: number): Promise {\n // TODO: Hook real outbound channel. For now, advance status only.\n await sheets.updateStatus(rowIndex, STATUS.DISPATCHED);\n}\n\n/** Mark error state on a row. Safe to call from anywhere. */\nexport async function markError(rowIndex: number, _reason: string): Promise {\n try {\n await sheets.updateStatus(rowIndex, STATUS.ERROR);\n } catch { /* swallow — error path */ }\n}\n\nexport { COL };\n",[],[145,180],"51e21182-47df-11f1-8db4-42b51c65c3df","llm.ts","019df40d-10bb-731b-b553-3265f12869ea",["D",1777915990125],"// ============================================================================\n// IntelligenceHub — GPT-4o \"Elite Conversion\" persona + niche-mapping.\n// Returns a strict AIPayload. Throws on 429 with provider tag for the boundary.\n// ============================================================================\n\nimport OpenAI from \"npm:openai\";\nimport { DEFAULT_CTA, LLM_MODEL, NICHE_RULES } from \"../config.ts\";\nimport type { AIPayload, Lead } from \"../types.ts\";\n\nconst SYSTEM_PROMPT = `You are \"Elite Conversion\" — a senior B2B copywriter who writes\nhigh-conversion outbound responses for inbound leads. Constraints:\n- 90–140 words, plain text, no markdown, no greetings like \"Hi \" unless you have a name.\n- Open with a sharp observation about the lead's stated context.\n- Provide exactly one concrete next step that uses the {{CTA_LINK}} placeholder verbatim.\n- Tone: direct, expert, calmly confident. Zero fluff. No emojis.\n- Never invent facts. If the context is thin, ask one targeted qualifying question.\n- End with a single CTA sentence containing {{CTA_LINK}}.`;\n\nfunction detectNiche(context: string): { niche: string; cta: string } {\n for (const rule of NICHE_RULES) {\n if (rule.pattern.test(context)) return { niche: rule.niche, cta: rule.cta };\n }\n return { niche: \"general\", cta: DEFAULT_CTA };\n}\n\nfunction client(): OpenAI {\n const key = Deno.env.get(\"OPENAI_API_KEY\");\n if (!key) throw new Error(\"OPENAI_API_KEY env var is not set\");\n return new OpenAI({ apiKey: key });\n}\n\n/**\n * Generate an AIPayload for a lead. The CTA is *injected post-generation* by\n * replacing the {{CTA_LINK}} placeholder, guaranteeing the niche map wins\n * even if the model gets creative.\n */\nexport async function draftFor(lead: Pick): Promise {\n const { niche, cta } = detectNiche(lead.context_metadata ?? \"\");\n const openai = client();\n\n const userPrompt = [\n `Source: ${lead.source}`,\n `Contact: ${lead.contact_raw}`,\n `Niche tag: ${niche}`,\n `Context / metadata:`,\n lead.context_metadata || \"(none provided)\",\n \"\",\n `Write the outbound message now. Use {{CTA_LINK}} as the literal CTA URL placeholder.`,\n ].join(\"\\n\");\n\n let completion;\n try {\n completion = await openai.chat.completions.create({\n model: LLM_MODEL,\n temperature: 0.6,\n max_tokens: 350,\n messages: [\n { role: \"system\", content: SYSTEM_PROMPT },\n { role: \"user\", content: userPrompt },\n ],\n });\n } catch (e) {\n // OpenAI SDK throws APIError with `.status` — propagate so error-boundary\n // can detect 429 specifically.\n const err = e as { status?: number; message?: string };\n const wrapped = new Error(`OpenAI: ${err.message ?? \"unknown\"}`) as Error & {\n status?: number;\n provider?: string;\n };\n wrapped.status = err.status;\n wrapped.provider = \"openai\";\n throw wrapped;\n }\n\n const raw = completion.choices[0]?.message?.content?.trim() ?? \"\";\n const draft = raw.replaceAll(\"{{CTA_LINK}}\", cta);\n\n return {\n draft,\n niche,\n cta_link: cta,\n rationale: `Niche=${niche} via NICHE_RULES. Persona=Elite Conversion. Model=${LLM_MODEL}.`,\n generated_at: new Date().toISOString(),\n };\n}\n",[],[145,187],"51e20ba6-47df-11f1-8db4-42b51c65c3df","idempotency.ts","019df40d-10bb-731b-b553-2fa5cd83d2bc",["D",1777915990125],"// ============================================================================\n// Idempotency — SHA-256(`${contact_raw}|${source}`) → hex.\n// Used as the uid_hash column. Repeats are short-circuited at ingest.\n// ============================================================================\n\nexport async function uidHash(contact_raw: string, source: string): Promise {\n const data = new TextEncoder().encode(`${contact_raw}|${source}`);\n const buf = await crypto.subtle.digest(\"SHA-256\", data);\n return [...new Uint8Array(buf)]\n .map((b) => b.toString(16).padStart(2, \"0\"))\n .join(\"\");\n}\n",[],[145,194],"51e1f940-47df-11f1-8db4-42b51c65c3df","auth.ts","019df40d-10bb-731b-b553-2870f8698421",["D",1777915990125],"// ============================================================================\n// AuthService — Google Service Account → Bearer access token.\n// Implements RFC7523 JWT bearer flow against Google's OAuth2 token endpoint.\n// Cached in-process for ~50 minutes to avoid re-signing on every request.\n// ============================================================================\n\nimport { create, getNumericDate } from \"https://deno.land/x/djwt@v3.0.2/mod.ts\";\n\ninterface ServiceAccountKey {\n client_email: string;\n private_key: string;\n token_uri?: string;\n}\n\ninterface CachedToken {\n token: string;\n expiresAt: number; // epoch ms\n}\n\nlet cache: CachedToken | null = null;\n\n/** Load + parse the GOOGLE_JSON env var. Throws if missing/invalid. */\nfunction loadKey(): ServiceAccountKey {\n const raw = Deno.env.get(\"GOOGLE_JSON\");\n if (!raw) throw new Error(\"GOOGLE_JSON env var is not set\");\n let parsed: ServiceAccountKey;\n try {\n parsed = JSON.parse(raw);\n } catch {\n throw new Error(\"GOOGLE_JSON is not valid JSON\");\n }\n if (!parsed.client_email || !parsed.private_key) {\n throw new Error(\"GOOGLE_JSON missing client_email or private_key\");\n }\n return parsed;\n}\n\n/** Convert a PEM-encoded PKCS#8 private key into a CryptoKey for RS256. */\nasync function importPrivateKey(pem: string): Promise {\n const cleaned = pem\n .replace(/-----BEGIN PRIVATE KEY-----/g, \"\")\n .replace(/-----END PRIVATE KEY-----/g, \"\")\n .replace(/\\\\n/g, \"\\n\")\n .replace(/\\s+/g, \"\");\n const der = Uint8Array.from(atob(cleaned), (c) => c.charCodeAt(0));\n return await crypto.subtle.importKey(\n \"pkcs8\",\n der,\n { name: \"RSASSA-PKCS1-v1_5\", hash: \"SHA-256\" },\n false,\n [\"sign\"],\n );\n}\n\n/**\n * Returns a fresh Google access token with sheets scope.\n * Cached for ~50 minutes (token TTL is 60m).\n */\nexport async function getAccessToken(): Promise {\n if (cache && Date.now() < cache.expiresAt) return cache.token;\n\n const key = loadKey();\n const cryptoKey = await importPrivateKey(key.private_key);\n\n const now = getNumericDate(0);\n const exp = getNumericDate(60 * 60); // 1h\n const jwt = await create(\n { alg: \"RS256\", typ: \"JWT\" },\n {\n iss: key.client_email,\n scope: \"https://www.googleapis.com/auth/spreadsheets\",\n aud: key.token_uri ?? \"https://oauth2.googleapis.com/token\",\n iat: now,\n exp,\n },\n cryptoKey,\n );\n\n const tokenUrl = key.token_uri ?? \"https://oauth2.googleapis.com/token\";\n const resp = await fetch(tokenUrl, {\n method: \"POST\",\n headers: { \"Content-Type\": \"application/x-www-form-urlencoded\" },\n body: new URLSearchParams({\n grant_type: \"urn:ietf:params:oauth:grant-type:jwt-bearer\",\n assertion: jwt,\n }),\n });\n if (!resp.ok) {\n const body = await resp.text();\n throw new Error(`Google token exchange failed (${resp.status}): ${body}`);\n }\n const json = await resp.json() as { access_token: string; expires_in: number };\n cache = {\n token: json.access_token,\n expiresAt: Date.now() + (json.expires_in - 600) * 1000, // refresh 10m early\n };\n return cache.token;\n}\n\n/** Force-clear the cache (e.g. on 401/403 retry). */\nexport function invalidateAuthCache() {\n cache = null;\n}\n\n/** Dev helper: return the service account email without exposing the key. */\nexport function serviceAccountEmail(): string {\n return loadKey().client_email;\n}\n",[],[145,201],["D",1777915990125],[210,211,212,213],[19],{"_36":97,"_13":98,"_67":99,"_69":70,"_71":72,"_73":74,"_75":76,"_38":223,"_17":34,"_78":101,"_80":-5,"_82":53,"_83":-5,"_118":224,"_18":225},{"_36":91,"_13":92,"_67":93,"_69":70,"_71":72,"_73":74,"_75":76,"_38":220,"_17":34,"_78":24,"_80":95,"_82":53,"_83":-5,"_118":221,"_18":222},{"_36":85,"_13":86,"_67":87,"_69":70,"_71":72,"_73":74,"_75":76,"_38":217,"_17":34,"_78":24,"_80":89,"_82":53,"_83":-5,"_118":218,"_18":219},{"_36":65,"_13":66,"_67":68,"_69":70,"_71":72,"_73":74,"_75":76,"_38":214,"_17":34,"_78":79,"_80":81,"_82":53,"_83":-5,"_118":215,"_18":216},["D",1777915990125],[],[19,66],["D",1777915990125],[],[19,86],["D",1777915990125],[],[19,92],["D",1777915990125],[226,227],[19,98],{"_36":235,"_13":236,"_67":237,"_69":99,"_71":72,"_73":74,"_75":76,"_38":238,"_17":34,"_78":79,"_80":239,"_82":53,"_83":-5,"_118":240,"_18":241},{"_36":228,"_13":229,"_67":230,"_69":99,"_71":72,"_73":74,"_75":76,"_38":231,"_17":34,"_78":79,"_80":232,"_82":53,"_83":-5,"_118":233,"_18":234},"51e1d348-47df-11f1-8db4-42b51c65c3df","LeadsTable.tsx","019df40d-10ba-777e-b50d-46f92cf1f341",["D",1777915990125],"/** @jsxImportSource https://esm.sh/react@18.2.0 */\nimport { useState } from \"https://esm.sh/react@18.2.0\";\nimport type { Lead } from \"../../types.ts\";\n\nconst STATUS_COLOR: Record = {\n 0: \"bg-gray-100 text-gray-700\",\n 1: \"bg-amber-100 text-amber-800\",\n 2: \"bg-blue-100 text-blue-800\",\n 3: \"bg-violet-100 text-violet-800\",\n 4: \"bg-emerald-100 text-emerald-800\",\n 5: \"bg-red-100 text-red-800\",\n};\n\nexport function LeadsTable(\n { leads, statusLabels }: { leads: Lead[]; statusLabels: Record },\n) {\n if (leads.length === 0) {\n return (\n

\n No leads yet. POST one to /api/lead to begin.\n

\n );\n }\n return (\n

\n \n \n \n \n \n \n \n \n \n \n \n \n \n \n {leads.map((l) => )}\n \n

#	Status	When	Source	Contact	Context	Priority	Draft

\n );\n}\n\nfunction Row({ lead, statusLabels }: { lead: Lead; statusLabels: Record }) {\n const [open, setOpen] = useState(false);\n const cls = STATUS_COLOR[lead.status_id] ?? STATUS_COLOR[0];\n const draftPreview = previewDraft(lead.ai_payload);\n return (\n <>\n \n {lead.rowIndex}\n \n \n {lead.status_id} · {statusLabels[String(lead.status_id)] ?? \"?\"}\n \n \n {formatTime(lead.timestamp)}\n {lead.source}\n \n {lead.contact_raw}\n \n \n {lead.context_metadata || \"—\"}\n \n {lead.priority_score}\n \n {lead.ai_payload\n ? (\n setOpen((o) => !o)}\n class=\"text-blue-600 hover:underline text-xs\"\n >\n {open ? \"hide\" : \"show\"}\n \n )\n : —}\n \n \n {open && lead.ai_payload && (\n \n \n

\n              {draftPreview}\n

\n \n \n )}\n \n );\n}\n\nfunction previewDraft(raw: string): string {\n if (!raw) return \"\";\n try {\n const parsed = JSON.parse(raw);\n if (parsed && typeof parsed === \"object\" && \"draft\" in parsed) {\n return [\n `niche: ${parsed.niche}`,\n `cta: ${parsed.cta_link}`,\n \"\",\n parsed.draft,\n ].join(\"\\n\");\n }\n } catch { /* fallthrough */ }\n return raw;\n}\n\nfunction formatTime(iso: string): string {\n if (!iso) return \"—\";\n const d = new Date(iso);\n if (Number.isNaN(d.getTime())) return iso;\n return d.toISOString().replace(\"T\", \" \").slice(0, 16) + \"Z\";\n}\n",[],[19,98,229],"51e1b818-47df-11f1-8db4-42b51c65c3df","App.tsx","019df40d-10ba-777e-b50d-4261f3daa225",["D",1777915990125],"/** @jsxImportSource https://esm.sh/react@18.2.0 */\nimport { useEffect, useState } from \"https://esm.sh/react@18.2.0\";\nimport { LeadsTable } from \"./LeadsTable.tsx\";\nimport type { Lead, StatusId } from \"../../types.ts\";\n\ninterface ApiResponse {\n leads: Lead[];\n statusLabels: Record;\n}\n\nexport function App() {\n const [data, setData] = useState(null);\n const [error, setError] = useState(null);\n const [loading, setLoading] = useState(true);\n const [autoRefresh, setAutoRefresh] = useState(true);\n\n async function load() {\n try {\n const r = await fetch(\"/api/leads\");\n if (!r.ok) throw new Error(`HTTP ${r.status}`);\n const json = (await r.json()) as ApiResponse;\n setData(json);\n setError(null);\n } catch (e) {\n setError((e as Error).message);\n } finally {\n setLoading(false);\n }\n }\n\n useEffect(() => {\n load();\n }, []);\n\n useEffect(() => {\n if (!autoRefresh) return;\n const id = setInterval(load, 15000);\n return () => clearInterval(id);\n }, [autoRefresh]);\n\n const counts = (data?.leads ?? []).reduce>(\n (acc, l) => {\n acc[l.status_id] = (acc[l.status_id] ?? 0) + 1;\n return acc;\n },\n {} as Record,\n );\n\n return (\n

Omni-Revenue Orchestrator

\n Event-driven CRM triage · Hono + React + Sequential Pipeline\n

\n \n setAutoRefresh((e.target as HTMLInputElement).checked)}\n />\n auto-refresh\n \n \n Reload\n \n \n View source\n \n

\n\n \n\n

\n {loading &&

Loading…

}\n {error && (\n

\n Failed to load: {error}\n

\n Hit /admin/init to verify Service Account + Telegram\n webhook.\n

\n )}\n {data && }\n

\n\n \n

\n );\n}\n\nfunction StatusStrip(\n { counts, labels }: { counts: Record; labels: Record },\n) {\n const entries: Array<[number, string]> = [\n [0, \"INGESTED\"],\n [1, \"ENRICHED\"],\n [2, \"DRAFTED\"],\n [3, \"REVIEWED\"],\n [4, \"DISPATCHED\"],\n [5, \"ERROR\"],\n ];\n return (\n

\n {entries.map(([id, label]) => (\n \n

\n {labels[String(id)] ?? label}\n

{counts[id] ?? 0}

\n ))}\n \n );\n}\n",[],[19,98,236],"51e1b5ca-47df-11f1-8db4-42b51c65c3df","cron","019df40d-10ba-777e-b50d-3f35f0452edf",["D",1777915990125],[248],[243],{"_36":249,"_13":250,"_67":251,"_69":244,"_71":72,"_73":74,"_75":76,"_38":252,"_17":34,"_78":253,"_80":254,"_82":53,"_83":-5,"_118":255,"_18":256},"51e197fc-47df-11f1-8db4-42b51c65c3df","sweep.ts","019df40d-10ba-777e-b50d-3b3d0b695ec0",["D",1777915990125],"interval","// ============================================================================\n// ReclamationTask — every 15m, scan A2:H35 and rescue any rows whose\n// status_id < ENRICHED (i.e. INGESTED). Each is enriched, drafted, and a\n// C&C card is dispatched to the admin.\n// ============================================================================\n\nimport * as sheets from \"../services/sheets.ts\";\nimport * as pipeline from \"../services/pipeline.ts\";\nimport * as tg from \"../services/telegram.ts\";\nimport { STATUS } from \"../types.ts\";\n\nexport default async function (_interval: { lastRunAt?: Date }): Promise {\n const rows = await sheets.getSweepRows();\n const stale = rows.filter((r) => r.contact_raw && r.status_id < STATUS.ENRICHED);\n\n if (stale.length === 0) {\n console.log(`[sweep] clean — ${rows.length} rows scanned, none stale`);\n return;\n }\n\n console.log(`[sweep] ${stale.length} stale rows → enriching`);\n\n // Sequential by design: avoid hammering OpenAI with parallel calls from a cron.\n for (const lead of stale) {\n try {\n const drafted = await pipeline.enrichAndDraft(lead);\n await pipeline.presentForReview(drafted);\n } catch (e) {\n const err = e as Error & { status?: number; provider?: string };\n console.error(`[sweep] row ${lead.rowIndex} failed:`, err.message);\n await pipeline.markError(lead.rowIndex, err.message);\n await tg.alertAdmin(\n `Sweep failed on row ${lead.rowIndex}: ${err.provider ?? \"\"} ${err.status ?? \"\"} ${err.message}`,\n );\n }\n }\n}\n",[],[243,250],"51d5373c-47df-11f1-8db4-42b51c65c3df",["D",1777915990125],"legacyEnvVars","httpPrivacy","description","Event-driven CRM triage: Sheets + GPT-4o + Telegram C&C cards","imageUrl","userId","deebfef6-6a8a-48c2-bc95-7806aa5a064a","pinnedFileId","pinPreview","pinMigrated","screenshotVersion","likeCount","019df401-3ef4-7079-ae55-7cdae8d79f07","tursoName","51d5373c47df11f18db442b51c65c3df","tursoHostname","51d5373c47df11f18db442b51c65c3df-val-town.aws-us-east-2.turso.io","tursoMeasuredAt",["D",1789507240000],"pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_11":12,"_304":300},"org",{"_11":12,"_297":298,"_299":300,"_264":265,"_301":302,"_303":53},"branch",{"_17":124,"_13":16,"_36":72,"_42":257,"_45":37,"_47":44,"_294":55,"_295":43,"_296":59,"_60":14,"_56":12},"forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","displayName","Ras TiTOZ","avatar","https://lh3.googleusercontent.com/a/ACg8ocIWmle2AhLnPo2zMfXYiWTWlWYMzrtjuNqz9ILnNfSs2C5xBw=s96-c","tier","free","canRestrictVals","profileImageUrl","adoptOrgId",{"_36":257,"_13":14,"_38":411,"_51":-5,"_259":53,"_54":55,"_260":55,"_261":262,"_263":-5,"_264":265,"_266":123,"_267":76,"_268":-5,"_269":-5,"_270":34,"_58":271,"_272":273,"_274":275,"_276":412,"_278":-5,"_279":280,"_281":280,"_282":283,"_284":283,"_285":283,"_286":280,"_287":280,"_288":413,"_290":414,"_292":415,"_52":53},[348,350,357,365,366,367,368],"files",[348,349,350,351,352,353,354,355,356,357,358,359,360,361,362,363,364,365,366,367,368],"counts",{"_339":34,"_340":74,"_341":34,"_35":342,"_343":344},[331,332,333,334],{"_36":103,"_13":19,"_67":70,"_69":-5,"_71":72,"_73":74,"_75":76,"_38":104,"_17":34,"_78":101,"_80":-5,"_82":53,"_83":-5,"_18":330},"upstreamProject",{"_36":43,"_13":14,"_261":262,"_263":-5,"_54":55,"_288":328},"upstreamBranch",{"_36":37,"_38":326,"_40":327,"_13":16,"_42":43,"_17":44,"_45":46,"_47":48,"_49":50,"_51":-5,"_52":53,"_54":55,"_56":57,"_58":59,"_60":14},"emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},["D",1777912405533],["D",1777912670090],{"_11":57,"_304":329},"https://lh3.googleusercontent.com/a/ACg8ocKAVWQwZW0HDu2P0iG-bOFSeBKPnWn5bXjW3O7e58TlwaVw=s96-c",[19],{"_36":97,"_13":98,"_67":99,"_69":70,"_71":72,"_73":74,"_75":76,"_38":100,"_17":34,"_78":101,"_80":-5,"_82":53,"_83":-5,"_18":338},{"_36":91,"_13":92,"_67":93,"_69":70,"_71":72,"_73":74,"_75":76,"_38":94,"_17":34,"_78":24,"_80":95,"_82":53,"_83":-5,"_18":337},{"_36":85,"_13":86,"_67":87,"_69":70,"_71":72,"_73":74,"_75":76,"_38":88,"_17":34,"_78":24,"_80":89,"_82":53,"_83":-5,"_18":336},{"_36":65,"_13":66,"_67":68,"_69":70,"_71":72,"_73":74,"_75":76,"_38":77,"_17":34,"_78":79,"_80":81,"_82":53,"_83":-5,"_18":335},[19,66],[19,86],[19,92],[19,98],"pulls","branches","forks",{"_345":34,"_347":34},"connections",{"_345":34,"_346":34},"count","unfilledCount","emptyCount",{"_36":242,"_13":243,"_67":244,"_69":-5,"_71":72,"_73":74,"_75":76,"_38":245,"_17":34,"_78":101,"_80":-5,"_82":53,"_83":-5,"_118":409,"_18":410},{"_36":249,"_13":250,"_67":251,"_69":244,"_71":72,"_73":74,"_75":76,"_38":252,"_17":34,"_78":253,"_80":254,"_82":53,"_83":-5,"_118":407,"_18":408},{"_36":103,"_13":19,"_67":70,"_69":-5,"_71":72,"_73":74,"_75":76,"_38":207,"_17":34,"_78":101,"_80":-5,"_82":53,"_83":-5,"_118":405,"_18":406},{"_36":97,"_13":98,"_67":99,"_69":70,"_71":72,"_73":74,"_75":76,"_38":223,"_17":34,"_78":101,"_80":-5,"_82":53,"_83":-5,"_118":403,"_18":404},{"_36":235,"_13":236,"_67":237,"_69":99,"_71":72,"_73":74,"_75":76,"_38":238,"_17":34,"_78":79,"_80":239,"_82":53,"_83":-5,"_118":401,"_18":402},{"_36":228,"_13":229,"_67":230,"_69":99,"_71":72,"_73":74,"_75":76,"_38":231,"_17":34,"_78":79,"_80":232,"_82":53,"_83":-5,"_118":399,"_18":400},{"_36":91,"_13":92,"_67":93,"_69":70,"_71":72,"_73":74,"_75":76,"_38":220,"_17":34,"_78":24,"_80":95,"_82":53,"_83":-5,"_118":397,"_18":398},{"_36":85,"_13":86,"_67":87,"_69":70,"_71":72,"_73":74,"_75":76,"_38":217,"_17":34,"_78":24,"_80":89,"_82":53,"_83":-5,"_118":395,"_18":396},{"_36":65,"_13":66,"_67":68,"_69":70,"_71":72,"_73":74,"_75":76,"_38":214,"_17":34,"_78":79,"_80":81,"_82":53,"_83":-5,"_118":393,"_18":394},{"_36":144,"_13":145,"_67":146,"_69":-5,"_71":72,"_73":74,"_75":76,"_38":147,"_17":34,"_78":101,"_80":-5,"_82":53,"_83":-5,"_118":391,"_18":392},{"_36":200,"_13":201,"_67":202,"_69":146,"_71":72,"_73":74,"_75":76,"_38":203,"_17":34,"_78":79,"_80":204,"_82":53,"_83":-5,"_118":389,"_18":390},{"_36":193,"_13":194,"_67":195,"_69":146,"_71":72,"_73":74,"_75":76,"_38":196,"_17":34,"_78":79,"_80":197,"_82":53,"_83":-5,"_118":387,"_18":388},{"_36":186,"_13":187,"_67":188,"_69":146,"_71":72,"_73":74,"_75":76,"_38":189,"_17":34,"_78":79,"_80":190,"_82":53,"_83":-5,"_118":385,"_18":386},{"_36":179,"_13":180,"_67":181,"_69":146,"_71":72,"_73":32,"_75":76,"_38":182,"_17":74,"_78":79,"_80":183,"_82":53,"_83":-5,"_118":383,"_18":384},{"_36":172,"_13":173,"_67":174,"_69":146,"_71":72,"_73":74,"_75":76,"_38":175,"_17":34,"_78":79,"_80":176,"_82":53,"_83":-5,"_118":381,"_18":382},{"_36":164,"_13":165,"_67":166,"_69":146,"_71":72,"_73":167,"_75":76,"_38":168,"_17":34,"_78":79,"_80":169,"_82":53,"_83":-5,"_118":379,"_18":380},{"_36":157,"_13":158,"_67":159,"_69":146,"_71":72,"_73":74,"_75":76,"_38":160,"_17":34,"_78":79,"_80":161,"_82":53,"_83":-5,"_118":377,"_18":378},{"_36":137,"_13":138,"_67":139,"_69":-5,"_71":72,"_73":74,"_75":76,"_38":140,"_17":34,"_78":24,"_80":141,"_82":53,"_83":-5,"_118":375,"_18":376},{"_36":130,"_13":131,"_67":132,"_69":-5,"_71":72,"_73":74,"_75":76,"_38":133,"_17":34,"_78":79,"_80":134,"_82":53,"_83":-5,"_118":373,"_18":374},{"_36":121,"_13":122,"_67":123,"_69":-5,"_71":72,"_73":124,"_75":76,"_38":125,"_17":74,"_78":126,"_80":127,"_82":53,"_83":-5,"_118":371,"_18":372},{"_36":113,"_13":114,"_67":115,"_69":-5,"_71":72,"_73":74,"_75":76,"_38":116,"_17":34,"_78":79,"_80":117,"_82":53,"_83":-5,"_118":369,"_18":370},[],[114],[],[122],[],[131],[],[138],[],[145,158],[],[145,165],[],[145,173],[],[145,180],[],[145,187],[],[145,194],[],[145,201],[358,359,360,361,362,363,364],[145],[],[19,66],[],[19,86],[],[19,92],[],[19,98,229],[],[19,98,236],[352,353],[19,98],[351,354,355,356],[19],[],[243,250],[349],[243],["D",1777915990125],["D",1789507240000],{"_11":12,"_304":300},{"_11":12,"_297":298,"_299":300,"_264":265,"_301":302,"_303":53},{"_17":124,"_13":16,"_36":72,"_42":257,"_45":37,"_47":44,"_294":55,"_295":43,"_296":59,"_60":14,"_56":12},"ctx",{"_288":-5,"_323":449,"_450":451,"_452":453,"_454":53,"_455":53,"_456":53,"_457":76,"_458":-5,"_459":-7,"_460":-7,"_461":34,"_462":53,"_463":53,"_464":-5,"_465":53,"_466":53,"_467":53,"_468":-5},"ENV",{"_420":421,"_422":423,"_424":16,"_425":426,"_427":428,"_429":430,"_431":432,"_433":434,"_435":436,"_437":438,"_439":440,"_441":442,"_443":444,"_445":446,"_447":448},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","RENDER_GIT_COMMIT","fdb67791413f4386b4dbf18f354029a617f6160f","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"]