[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8},"actionData","errors","root",{"_109":110,"_111":112},"routes/embed.x.$handle.$name.$",{"_9":10,"_11":12,"_13":14,"_15":16,"_17":18,"_19":20,"_21":-5},"handle","dlxdesigns","name","dlx-lead-engine","path","backend/hunt.ts","project",{"_22":48,"_11":12,"_35":49,"_50":-5,"_51":44,"_52":53,"_54":53,"_55":56,"_57":-5,"_58":59,"_60":61,"_62":34,"_63":-5,"_64":-5,"_65":66,"_67":68,"_69":70,"_71":72,"_73":74,"_75":-5,"_76":77,"_78":77,"_79":80,"_81":80,"_82":80,"_83":77,"_84":77,"_85":86,"_87":88,"_89":90,"_91":44},"file",{"_22":23,"_11":24,"_25":26,"_27":28,"_29":30,"_31":32,"_33":34,"_35":36,"_37":38,"_39":40,"_41":42,"_43":44,"_45":-5,"_13":46},"permalink","https://www.val.town/x/dlxdesigns/dlx-lead-engine/code/backend/hunt.ts","extension","id","c410888c-4a87-4470-a3df-8bcc00cc17b4","hunt.ts","fileId","a81c406a-a813-11f1-8400-1607ee4eb77e","parentId","d38f0135-22f5-4812-8494-7da7f19be33c","branchId","faea9245-6732-47d9-a1a2-3550998bc296","branchVersion",54,"latest",true,"createdAt",["D",1788494704673],"version",1,"fileType","script","content","// backend/hunt.ts\n// HUNT — the autonomous ingestion layer.\n//\n// This is the honest form of \"hunting\": it watches a REAL, configured source\n// and feeds genuinely captured inquiries through the qualifier into the\n// pipeline. It never invents people, names, or signals — it only ingests what\n// the source actually contains.\n//\n// Configure one or more real sources:\n// DLX_HUNT_URL — a JSON or CSV endpoint / published feed.\n// DLX_HUNT_TOKEN — optional bearer token sent as `Authorization: Bearer …`\n// (e.g. for a private feed).\n//\n// JSON response shape (either a bare array or wrapped):\n// { \"leads\": [ { name, gmail, phone, message, source, source_url } , ... ] }\n//\n// CSV: a published Google Sheet CSV is accepted directly. First row must be a\n// header that includes at least `gmail` (plus optional name, phone, message,\n// source, source_url). Google Sheets: File → Share → Publish to web → CSV,\n// copy the link, use it as DLX_HUNT_URL.\n//\n// Deduplication is automatic: the store's unique gmail constraint means a lead\n// already in the pipeline is skipped, so the poller is idempotent and safe to\n// run on a cron.\nimport { ingestLead, type InboundLead } from \"./worker/ingest.ts\";\n\nexport interface HuntResult {\n source: string;\n fetched: number;\n qualified: number;\n rejected: number;\n duplicates: number;\n}\n\nexport async function hunt(now = new Date()): Promise {\n const url = Deno.env.get(\"DLX_HUNT_URL\");\n const token = Deno.env.get(\"DLX_HUNT_TOKEN\");\n const result: HuntResult = { source: url ?? \"(none)\", fetched: 0, qualified: 0, rejected: 0, duplicates: 0 };\n\n if (!url) {\n console.log(`hunt: no DLX_HUNT_URL configured at ${now.toISOString()}`);\n return result;\n }\n\n const headers: Record = { Accept: \"text/csv, application/json, text/plain\" };\n if (token) headers.Authorization = `Bearer ${token}`;\n\n let text: string;\n try {\n const res = await fetch(url, { headers });\n if (!res.ok) throw new Error(`HTTP ${res.status}`);\n text = await res.text();\n } catch (err) {\n console.error(\"hunt: fetch failed from source:\", err);\n return result;\n }\n\n const trimmed = text.trim();\n const looksJson = trimmed.startsWith(\"{\") || trimmed.startsWith(\"[\");\n const rows: Record[] = looksJson\n ? jsonlize(trimmed)\n : csvlize(trimmed);\n\n for (const item of rows) {\n if (!item.gmail) continue; // evidence-less rows are ignored, never invented\n result.fetched++;\n const outcome = await ingestLead(item as unknown as InboundLead);\n if (outcome.decision === \"pass\") {\n result.qualified++;\n } else if (\n typeof outcome.reason === \"string\" &&\n outcome.reason.includes(\"duplicate\")\n ) {\n result.duplicates++;\n } else {\n result.rejected++;\n }\n }\n\n console.log(\n `hunt ${now.toISOString()} source=${result.source} fetched=${result.fetched} qualified=${result.qualified} rejected=${result.rejected} duplicates=${result.duplicates}`,\n );\n return result;\n}\n\nfunction jsonlize(text: string): Record[] {\n let payload: unknown;\n try {\n payload = JSON.parse(text);\n } catch {\n return [];\n }\n if (Array.isArray(payload)) return payload as Record[];\n if (Array.isArray((payload as { leads?: unknown[] })?.leads)) {\n return (payload as { leads: unknown[] }).leads as Record[];\n }\n return [];\n}\n\n/** Minimal RFC-4180-ish CSV parser (handles quoted fields and embedded commas). */\nfunction csvlize(text: string): Record[] {\n const lines = splitCsvLines(text);\n if (lines.length < 2) return [];\n const header = parseCsvLine(lines[0]).map((h) => h.trim().toLowerCase());\n const gidx = header.indexOf(\"gmail\");\n if (gidx === -1) return []; // must have a gmail column\n const out: Record[] = [];\n for (let i = 1; i < lines.length; i++) {\n const cells = parseCsvLine(lines[i]);\n if (!cells[gidx]?.trim()) continue;\n const row: Record = {};\n header.forEach((h, j) => {\n if (h) row[h] = (cells[j] ?? \"\").trim();\n });\n if (row.gmail) out.push(row);\n }\n return out;\n}\n\nfunction splitCsvLines(text: string): string[] {\n const out: string[] = [];\n let cur = \"\";\n let inQ = false;\n for (let i = 0; i < text.length; i++) {\n const ch = text[i];\n if (ch === '\"') {\n inQ = !inQ;\n cur += ch;\n } else if (ch === \"\\n\" && !inQ) {\n out.push(cur);\n cur = \"\";\n } else {\n cur += ch;\n }\n }\n if (cur.trim()) out.push(cur);\n return out;\n}\n\nfunction parseCsvLine(line: string): string[] {\n const cells: string[] = [];\n let cur = \"\";\n let inQ = false;\n for (let i = 0; i < line.length; i++) {\n const ch = line[i];\n if (ch === '\"') {\n if (inQ && line[i + 1] === '\"') {\n cur += '\"';\n i++;\n } else {\n inQ = !inQ;\n }\n } else if (ch === \",\" && !inQ) {\n cells.push(cur);\n cur = \"\";\n } else {\n cur += ch;\n }\n }\n cells.push(cur);\n return cells;\n}\n","deleted",false,"label",[47,24],"backend","d2f8de76-3d02-4949-8a06-2f7cc759dae3",["D",1788452396724],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","DLX Designs lead qualification engine + React dashboard","imageUrl","userId","0e434874-725d-4e49-bc72-a0c364fc943f","pinnedFileId","01a06811-df40-730d-85ee-1ae96a373bd7","pinPreview","pinMigrated","screenshotVersion","likeCount",0,"orgId","01a04e8e-cc2d-73ad-9a1b-036254519f63","tursoName","d2f8de763d0249498a062f7cc759dae3","tursoHostname","d2f8de763d0249498a062f7cc759dae3-val-town.aws-us-east-2.turso.io","tursoMeasuredAt",["D",1789494036282],"pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_9":10,"_108":-5},"org",{"_9":10,"_102":103,"_104":-5,"_58":-5,"_105":106,"_107":44},"branch",{"_37":92,"_11":93,"_22":30,"_94":48,"_95":-5,"_96":-5,"_97":-5,"_98":-5,"_99":-5,"_100":12,"_101":10},"isOwned",88,"main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","displayName","DLXdesigns ","avatar","tier","free","canRestrictVals","profileImageUrl","ctx",{"_85":-5,"_142":143,"_144":145,"_146":147,"_148":44,"_149":44,"_150":44,"_151":34,"_152":-5,"_153":-7,"_154":-7,"_155":66,"_156":44,"_157":44,"_158":-5,"_159":44,"_160":44,"_161":44,"_162":-5},"ENV",{"_113":114,"_115":116,"_117":93,"_118":119,"_120":121,"_122":123,"_124":125,"_126":127,"_128":129,"_130":131,"_132":133,"_134":135,"_136":137,"_138":139,"_140":141},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","RENDER_GIT_COMMIT","e87eb04e707cf64e7e532c8e8ec395f209e17f15","RENDER_GIT_BRANCH","POSTHOG_API_TOKEN","phc_nmoyuAkStEZuUp69rYlg1DZgrIt19Gx0Y4Hwf8tGgJP","POSTHOG_API_HOST","https://wart.val.town","WEB_API_TEMPLATE","https://{val}.web.val.run","APP_URL","https://www.val.town","MODULE_URL","https://esm.town","VANITY_WEB_API_TEMPLATE","https://{label}.val.run/","DENOLS_URL","https://lsp.val.town","NODE_ENV","production","CLOUDFLARE_TURNSTILE_SITE_KEY","0x4AAAAAACtaIZJH7s9rBMZ6","GOOGLE_CLIENT_ID","875989696899-jtsqkhlbdv5jrlsk8631p7ipjg3c6o62.apps.googleusercontent.com","STRIPE_PUBLISHABLE_KEY","pk_live_51N2zvWEpZTTLipIkVEwXrUG9AT0yeOOEYxszarZT1jpsZV58Ly6wlg3SltZpHN26CUalOBmUSY7adQRQiSkCZz2500qSXNkf8Y","API_URL","https://api.val.town","orgs",[],"preferencesKeybindings","default","preferencesTheme","light","preferencesFixers","preferencesCopilot","preferencesSelectionAi","preferencesCloseBrackets","preferencesChatPanelState","preferencesDprint","preferencesDenofmt","notificationCount","flagDenols","isBusinessOrgMember","businessOrgHandle","isBusinessOrgAdmin","isHigherTownieTier","navCollapsed","currentOrgId"]