\n \n \n \n",[],[200,217],"3ec9b404-47dc-11f1-bb94-42b51c65c3df","favicon.svg","019df3f8-ea52-731e-a6b6-9da29593072d",["D",1777914669570],"\n",[],[200,224],"3ec9b2a6-47dc-11f1-bb94-42b51c65c3df","components","019df3f8-ea52-731e-a6b6-9bfa0b8238ab",["D",1777914669570],[236,237],[200,231],{"_36":245,"_13":246,"_70":247,"_72":232,"_74":75,"_76":248,"_78":79,"_38":249,"_17":81,"_82":83,"_84":250,"_86":53,"_87":-5,"_143":251,"_18":252},{"_36":238,"_13":239,"_70":240,"_72":232,"_74":75,"_76":81,"_78":79,"_38":241,"_17":34,"_82":83,"_84":242,"_86":53,"_87":-5,"_143":243,"_18":244},"3ec99ee2-47dc-11f1-bb94-42b51c65c3df","LeadsTable.tsx","019df3f8-ea52-731e-a6b6-9664910aefaf",["D",1777914669570],"/** @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",[],[200,231,239],"93c1eac6-47dc-11f1-915d-42b51c65c3df","App.tsx","019df3f8-ea52-731e-a6b6-9103d7d4dfe9",6,["D",1777914812240],"/** @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\n/** Read admin_key from the page URL so /api/leads can be called with the same gate. */\nfunction adminKeyFromUrl(): string | null {\n if (typeof window === \"undefined\") return null;\n return new URLSearchParams(window.location.search).get(\"admin_key\");\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 key = adminKeyFromUrl();\n const url = key\n ? `/api/leads?admin_key=${encodeURIComponent(key)}`\n : \"/api/leads\";\n const r = await fetch(url);\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 + Hot-Path 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 Check that ?admin_key=… is in the URL and matches the{\" \"}\n ADMIN_KEY env var. Hit{\" \"}\n /admin/init?admin_key=… to verify Service Account +\n Telegram 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",[],[200,231,246],"3ec97d4a-47dc-11f1-bb94-42b51c65c3df","cron","019df3f8-ea52-731e-a6b6-8d8b6ba82ffe",["D",1777914669570],[259],[254],{"_36":260,"_13":261,"_70":262,"_72":255,"_74":75,"_76":81,"_78":79,"_38":263,"_17":34,"_82":264,"_84":265,"_86":53,"_87":-5,"_143":266,"_18":267},"3ec94e42-47dc-11f1-bb94-42b51c65c3df","sweep.ts","019df3f8-ea52-731e-a6b6-89fc1d718505",["D",1777914669570],"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",[],[254,261],"3eb91040-47dc-11f1-bb94-42b51c65c3df",["D",1777914669570],"legacyEnvVars","httpPrivacy","description","Event-driven CRM triage: Sheets + GPT-4o + Telegram C&C cards","imageUrl","userId","7c9c86e1-fe9c-473d-9022-88548bd27a5a","pinnedFileId","pinPreview","pinMigrated","screenshotVersion","likeCount","019df3df-cdd2-72eb-9f42-94180885e35d","tursoName","3eb9104047dc11f1bb9442b51c65c3df","tursoHostname","3eb9104047dc11f1bb9442b51c65c3df-val-town.aws-us-east-2.turso.io","tursoMeasuredAt",["D",1789506649022],"pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_11":12,"_315":311},"org",{"_11":12,"_308":309,"_310":311,"_275":276,"_312":313,"_314":53},"branch",{"_17":248,"_13":16,"_36":75,"_42":268,"_45":37,"_47":44,"_305":55,"_306":43,"_307":59,"_60":14,"_56":12},"forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","displayName","אילן כהן","avatar","https://lh3.googleusercontent.com/a/ACg8ocKair0LtxORBChLm___TzaXV5NfPUB_7hjJ9Ua5Ug7QvqyCWA=s96-c","tier","free","canRestrictVals","profileImageUrl","adoptOrgId",{"_36":268,"_13":14,"_38":428,"_51":-5,"_270":53,"_54":55,"_271":55,"_272":273,"_274":-5,"_275":276,"_277":148,"_278":79,"_279":-5,"_280":-5,"_281":34,"_58":282,"_283":284,"_285":286,"_287":429,"_289":-5,"_290":291,"_292":291,"_293":294,"_295":294,"_296":294,"_297":291,"_298":291,"_299":430,"_301":431,"_303":432,"_52":53},[365,367,374,382,383,384,385],"files",[365,366,367,368,369,370,371,372,373,374,375,376,377,378,379,380,381,382,383,384,385],"counts",{"_356":34,"_357":81,"_358":34,"_35":359,"_360":361},[342,343,344,345,346,347,348],{"_36":127,"_13":19,"_70":73,"_72":-5,"_74":75,"_76":81,"_78":79,"_38":128,"_17":34,"_82":129,"_84":-5,"_86":53,"_87":-5,"_18":341},"upstreamProject",{"_36":43,"_13":14,"_272":273,"_274":-5,"_54":55,"_299":339},"upstreamBranch",{"_36":37,"_38":337,"_40":338,"_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,"_315":340},"https://lh3.googleusercontent.com/a/ACg8ocKAVWQwZW0HDu2P0iG-bOFSeBKPnWn5bXjW3O7e58TlwaVw=s96-c",[19],{"_36":121,"_13":122,"_70":123,"_72":73,"_74":75,"_76":81,"_78":79,"_38":124,"_17":34,"_82":83,"_84":125,"_86":53,"_87":-5,"_18":355},{"_36":115,"_13":116,"_70":117,"_72":73,"_74":75,"_76":81,"_78":79,"_38":118,"_17":34,"_82":83,"_84":119,"_86":53,"_87":-5,"_18":354},{"_36":109,"_13":110,"_70":111,"_72":73,"_74":75,"_76":81,"_78":79,"_38":112,"_17":34,"_82":83,"_84":113,"_86":53,"_87":-5,"_18":353},{"_36":102,"_13":103,"_70":104,"_72":73,"_74":75,"_76":105,"_78":79,"_38":106,"_17":81,"_82":83,"_84":107,"_86":53,"_87":-5,"_18":352},{"_36":96,"_13":97,"_70":98,"_72":73,"_74":75,"_76":81,"_78":79,"_38":99,"_17":34,"_82":83,"_84":100,"_86":53,"_87":-5,"_18":351},{"_36":89,"_13":90,"_70":91,"_72":73,"_74":75,"_76":92,"_78":79,"_38":93,"_17":34,"_82":83,"_84":94,"_86":53,"_87":-5,"_18":350},{"_36":68,"_13":69,"_70":71,"_72":73,"_74":75,"_76":77,"_78":79,"_38":80,"_17":81,"_82":83,"_84":85,"_86":53,"_87":-5,"_18":349},[19,69],[19,90],[19,97],[19,103],[19,110],[19,116],[19,122],"pulls","branches","forks",{"_362":34,"_364":34},"connections",{"_362":34,"_363":34},"count","unfilledCount","emptyCount",{"_36":253,"_13":254,"_70":255,"_72":-5,"_74":75,"_76":81,"_78":79,"_38":256,"_17":34,"_82":129,"_84":-5,"_86":53,"_87":-5,"_143":426,"_18":427},{"_36":260,"_13":261,"_70":262,"_72":255,"_74":75,"_76":81,"_78":79,"_38":263,"_17":34,"_82":264,"_84":265,"_86":53,"_87":-5,"_143":424,"_18":425},{"_36":199,"_13":200,"_70":201,"_72":-5,"_74":75,"_76":81,"_78":79,"_38":202,"_17":34,"_82":129,"_84":-5,"_86":53,"_87":-5,"_143":422,"_18":423},{"_36":230,"_13":231,"_70":232,"_72":201,"_74":75,"_76":81,"_78":79,"_38":233,"_17":34,"_82":129,"_84":-5,"_86":53,"_87":-5,"_143":420,"_18":421},{"_36":245,"_13":246,"_70":247,"_72":232,"_74":75,"_76":248,"_78":79,"_38":249,"_17":81,"_82":83,"_84":250,"_86":53,"_87":-5,"_143":418,"_18":419},{"_36":238,"_13":239,"_70":240,"_72":232,"_74":75,"_76":81,"_78":79,"_38":241,"_17":34,"_82":83,"_84":242,"_86":53,"_87":-5,"_143":416,"_18":417},{"_36":223,"_13":224,"_70":225,"_72":201,"_74":75,"_76":81,"_78":79,"_38":226,"_17":34,"_82":24,"_84":227,"_86":53,"_87":-5,"_143":414,"_18":415},{"_36":216,"_13":217,"_70":218,"_72":201,"_74":75,"_76":81,"_78":79,"_38":219,"_17":34,"_82":24,"_84":220,"_86":53,"_87":-5,"_143":412,"_18":413},{"_36":209,"_13":210,"_70":211,"_72":201,"_74":75,"_76":81,"_78":79,"_38":212,"_17":34,"_82":83,"_84":213,"_86":53,"_87":-5,"_143":410,"_18":411},{"_36":127,"_13":19,"_70":73,"_72":-5,"_74":75,"_76":81,"_78":79,"_38":168,"_17":34,"_82":129,"_84":-5,"_86":53,"_87":-5,"_143":408,"_18":409},{"_36":121,"_13":122,"_70":123,"_72":73,"_74":75,"_76":81,"_78":79,"_38":196,"_17":34,"_82":83,"_84":125,"_86":53,"_87":-5,"_143":406,"_18":407},{"_36":115,"_13":116,"_70":117,"_72":73,"_74":75,"_76":81,"_78":79,"_38":193,"_17":34,"_82":83,"_84":119,"_86":53,"_87":-5,"_143":404,"_18":405},{"_36":109,"_13":110,"_70":111,"_72":73,"_74":75,"_76":81,"_78":79,"_38":190,"_17":34,"_82":83,"_84":113,"_86":53,"_87":-5,"_143":402,"_18":403},{"_36":102,"_13":103,"_70":104,"_72":73,"_74":75,"_76":105,"_78":79,"_38":187,"_17":81,"_82":83,"_84":107,"_86":53,"_87":-5,"_143":400,"_18":401},{"_36":96,"_13":97,"_70":98,"_72":73,"_74":75,"_76":81,"_78":79,"_38":184,"_17":34,"_82":83,"_84":100,"_86":53,"_87":-5,"_143":398,"_18":399},{"_36":89,"_13":90,"_70":91,"_72":73,"_74":75,"_76":92,"_78":79,"_38":181,"_17":34,"_82":83,"_84":94,"_86":53,"_87":-5,"_143":396,"_18":397},{"_36":68,"_13":69,"_70":71,"_72":73,"_74":75,"_76":77,"_78":79,"_38":178,"_17":81,"_82":83,"_84":85,"_86":53,"_87":-5,"_143":394,"_18":395},{"_36":161,"_13":162,"_70":163,"_72":-5,"_74":75,"_76":81,"_78":79,"_38":164,"_17":34,"_82":24,"_84":165,"_86":53,"_87":-5,"_143":392,"_18":393},{"_36":154,"_13":155,"_70":156,"_72":-5,"_74":75,"_76":81,"_78":79,"_38":157,"_17":34,"_82":83,"_84":158,"_86":53,"_87":-5,"_143":390,"_18":391},{"_36":146,"_13":147,"_70":148,"_72":-5,"_74":75,"_76":32,"_78":79,"_38":149,"_17":81,"_82":150,"_84":151,"_86":53,"_87":-5,"_143":388,"_18":389},{"_36":138,"_13":139,"_70":140,"_72":-5,"_74":75,"_76":81,"_78":79,"_38":141,"_17":34,"_82":83,"_84":142,"_86":53,"_87":-5,"_143":386,"_18":387},[],[139],[],[147],[],[155],[],[162],[],[19,69],[],[19,90],[],[19,97],[],[19,103],[],[19,110],[],[19,116],[],[19,122],[375,376,377,378,379,380,381],[19],[],[200,210],[],[200,217],[],[200,224],[],[200,231,239],[],[200,231,246],[369,370],[200,231],[368,371,372,373],[200],[],[254,261],[366],[254],["D",1777914669570],["D",1789506649022],{"_11":12,"_315":311},{"_11":12,"_308":309,"_310":311,"_275":276,"_312":313,"_314":53},{"_17":248,"_13":16,"_36":75,"_42":268,"_45":37,"_47":44,"_305":55,"_306":43,"_307":59,"_60":14,"_56":12},"ctx",{"_299":-5,"_334":466,"_467":468,"_469":470,"_471":53,"_472":53,"_473":53,"_474":79,"_475":-5,"_476":-7,"_477":-7,"_478":34,"_479":53,"_480":53,"_481":-5,"_482":53,"_483":53,"_484":53,"_485":-5},"ENV",{"_437":438,"_439":440,"_441":16,"_442":443,"_444":445,"_446":447,"_448":449,"_450":451,"_452":453,"_454":455,"_456":457,"_458":459,"_460":461,"_462":463,"_464":465},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","RENDER_GIT_COMMIT","5015b8df46402d8bba4f485ecc37aec202b0e06b","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"]