{title}

[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_272":273,"_274":275},"routes/_app.x.$handle.$name",{"_107":106,"_38":52,"_116":97,"_33":117,"_13":14,"_118":-5,"_11":119,"_120":121,"_122":123,"_124":125,"_126":127,"_26":-5,"_128":-5,"_129":-5,"_130":31,"_131":132,"_133":66,"_134":-5,"_135":-5,"_136":137},"routes/_app.x.$handle.$name.branch.$branch.version.$version.diff",{"_11":12,"_13":14,"_15":16,"_17":18,"_19":-5},"project",{"_50":51,"_38":52,"_45":53,"_54":-5,"_55":31,"_56":57,"_58":57,"_59":60,"_61":-5,"_19":62,"_63":64,"_65":66,"_67":-5,"_68":-5,"_69":70,"_71":72,"_73":74,"_75":76,"_77":78,"_79":-5,"_80":81,"_82":81,"_83":84,"_85":84,"_86":84,"_87":81,"_88":81,"_89":90,"_91":92,"_93":94,"_95":31},"version",59,"changes",[25],"aiChatInfo",{"_20":21,"_22":-5,"_23":-5,"_24":-5},"userId","aiChatMessageId","de342f66-bf28-4631-bba8-687baa5dac0b","aiChatThreadId","aiChatThreadUserId","aiChatThreadTitle",{"_26":27,"_28":29,"_30":31,"_32":31,"_33":34,"_35":34},"file",{"_36":37,"_38":39,"_40":41,"_42":44,"_45":46,"_47":14,"_48":49,"_30":31},"previous",{"_36":37,"_38":39,"_40":41,"_42":43},"deleted",false,"deletedHere","path","lib/hunter.ts","latestPath","fileId","a2ee9d56-a019-11f1-9af3-1607ee4eb77e","name","hunter.ts","fileType","script","content","// lib/hunter.ts\n// Market Hunt orchestrator: discovery -> Gemini qualification/scoring -> storage.\n// Stores qualified leads in the val's scoped SQLite DB with deduplication, hunt\n// history, and per-lead WhatsApp outreach deep links to IS-REAL's business line.\n\nimport { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\nimport {\n buildQueries,\n DiscoveryHit,\n fetchPageText,\n hasBuyerIntent,\n PRODUCT_CATEGORIES,\n searchWeb,\n} from \"./sources.ts\";\nimport {\n buildOpportunityPrompt,\n geminiJson,\n geminiGroundSearch,\n GEMINI_SEARCH_QUERIES,\n RawOpportunity,\n} from \"./gemini.ts\";\n\nexport const BUSINESS_WHATSAPP = \"2349160726032\";\nexport const WEBSITE = \"https://is-real-modern-furniture-gr29qv.v2.appdeploy.ai/\";\n\nconst MIN_INTENT = Number(Deno.env.get(\"MIN_INTENT_SCORE\") ?? 50);\nconst QUERY_LIMIT = Number(Deno.env.get(\"QUERY_LIMIT\") ?? 60);\n\n// --------------------------------------------------------------------------\n// Schema\n// --------------------------------------------------------------------------\nawait sqlite.execute(`CREATE TABLE IF NOT EXISTS leads (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n dedupe_key TEXT UNIQUE NOT NULL,\n buyer_name TEXT,\n company TEXT,\n phone TEXT,\n email TEXT,\n requirement TEXT NOT NULL,\n location TEXT,\n product_category TEXT,\n evidence_url TEXT NOT NULL,\n source TEXT,\n evidence_snippet TEXT,\n intent_score INTEGER,\n opportunity_value REAL,\n value_currency TEXT,\n confidence REAL,\n status TEXT DEFAULT 'new',\n whatsapp_link TEXT,\n outreach TEXT,\n discovery_method TEXT,\n first_seen_at TEXT DEFAULT CURRENT_TIMESTAMP,\n last_seen_at TEXT DEFAULT CURRENT_TIMESTAMP,\n updated_at TEXT DEFAULT CURRENT_TIMESTAMP\n)`);\n\n// Migration: add columns introduced after the table first shipped.\ntry { await sqlite.execute(`ALTER TABLE leads ADD COLUMN outreach TEXT`); } catch { /* already exists */ }\ntry { await sqlite.execute(`ALTER TABLE leads ADD COLUMN discovery_method TEXT`); } catch { /* already exists */ }\n\nawait sqlite.execute(`CREATE TABLE IF NOT EXISTS hunts (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n triggered_by TEXT DEFAULT 'cron',\n started_at TEXT,\n finished_at TEXT,\n status TEXT,\n queries_run INTEGER,\n hits_seen INTEGER,\n candidates INTEGER,\n new_leads INTEGER,\n duplicates INTEGER,\n rejected INTEGER,\n error TEXT\n)`);\n\n// --------------------------------------------------------------------------\n// Types\n// --------------------------------------------------------------------------\nexport interface LeadRow {\n id: number;\n buyer_name: string | null;\n company: string | null;\n phone: string | null;\n email: string | null;\n requirement: string;\n location: string | null;\n product_category: string | null;\n evidence_url: string;\n source: string | null;\n evidence_snippet: string | null;\n intent_score: number | null;\n opportunity_value: number | null;\n value_currency: string | null;\n confidence: number | null;\n status: string;\n whatsapp_link: string | null;\n outreach: string | null;\n discovery_method: string | null;\n first_seen_at: string;\n last_seen_at: string;\n}\n\nexport interface HuntResult {\n ok: boolean;\n huntId: number | null;\n triggeredBy: string;\n startedAt: string;\n finishedAt: string;\n status: string;\n queriesRun: number;\n hitsSeen: number;\n candidates: number;\n newLeads: number;\n duplicates: number;\n rejected: number;\n topLeads: LeadRow[];\n error?: string;\n}\n\n// --------------------------------------------------------------------------\n// Helpers\n// --------------------------------------------------------------------------\nasync function sha256(input: string): Promise {\n const data = new TextEncoder().encode(input);\n const digest = await crypto.subtle.digest(\"SHA-256\", data);\n return Array.from(new Uint8Array(digest))\n .map((b) => b.toString(16).padStart(2, \"0\"))\n .join(\"\");\n}\n\nexport async function dedupeKey(evidenceUrl: string, requirement: string, location: string): Promise {\n return sha256(\n `${evidenceUrl.trim().toLowerCase()}::${requirement.trim().toLowerCase()}::${(location ?? \"\").trim().toLowerCase()}`,\n );\n}\n\nfunction classifyProduct(requirement: string, evidence: string): string | null {\n const hay = `${requirement} ${evidence}`.toLowerCase();\n for (const cat of PRODUCT_CATEGORIES) {\n if (hay.includes(cat)) return cat;\n }\n return null;\n}\n\n/** Normalize a phone to the E.164 international form used by wa.me. Returns null\n * if it doesn't look like a valid phone number (never fabricates one). */\nexport function normalizePhone(p: string | null | undefined): string | null {\n if (!p) return null;\n let d = p.replace(/[^\\d]/g, \"\");\n if (d.length === 11 && d.startsWith(\"0\")) d = \"234\" + d.slice(1); // Nigerian 0NN...\n else if (d.length === 10 && d.startsWith(\"0\")) d = \"234\" + d.slice(1);\n else if (d.startsWith(\"+\")) d = d.slice(1);\n if (d.length < 10 || d.length > 15) return null;\n return d;\n}\n\n/** Build a wa.me deep link to the BUYER's phone with a pre-filled outreach message.\n * Only returns a link when a valid buyer phone number exists. */\nexport function buildWhatsAppLink(buyerPhone: string, message: string): string | null {\n const norm = normalizePhone(buyerPhone);\n if (!norm) return null;\n return `https://wa.me/${norm}?text=${encodeURIComponent(message)}`;\n}\n\nexport function businessWhatsApp(): string {\n return `https://wa.me/${BUSINESS_WHATSAPP}`;\n}\n\nfunction defaultOutreach(requirement: string, loc: string | null): string {\n return (\n `Hello, I'm from IS-REAL Modern Furniture (${WEBSITE}). I saw you are looking for ` +\n `\"${requirement}\"${loc ? ` in ${loc}` : \"\"}. We design and supply quality modern ` +\n `furniture in Nigeria. May I send you our catalogue and a quote?`\n );\n}\n\n// --------------------------------------------------------------------------\n// The hunt\n// --------------------------------------------------------------------------\nexport async function runHunt(options?: { source?: string }): Promise {\n const startedAt = new Date().toISOString();\n const triggeredBy = options?.source ?? \"manual\";\n let huntId: number | null = null;\n\n const fin = (\n partial: Partial & { status: string },\n ): HuntResult => {\n return {\n ok: partial.status === \"success\",\n huntId,\n triggeredBy,\n startedAt,\n finishedAt: new Date().toISOString(),\n queriesRun: partial.queriesRun ?? queriesRun,\n hitsSeen: partial.hitsSeen ?? hitsSeen,\n candidates: partial.candidates ?? candidates,\n newLeads: partial.newLeads ?? newLeads,\n duplicates: partial.duplicates ?? duplicates,\n rejected: partial.rejected ?? rejected,\n topLeads: partial.topLeads ?? [],\n status: partial.status,\n error: partial.error,\n };\n };\n\n let queriesRun = 0;\n let hitsSeen = 0;\n let candidates = 0;\n let newLeads = 0;\n let duplicates = 0;\n let rejected = 0;\n\n try {\n await sqlite.execute({\n sql: `INSERT INTO hunts (triggered_by, started_at, status) VALUES (?, ?, 'running')`,\n args: [triggeredBy, startedAt],\n });\n const r = (await sqlite.execute(\n \"SELECT last_insert_rowid() AS id\",\n ));\n const row = r.rows[0] as Record;\n huntId = Number(row.id);\n\n // 1) Discover evidence.\n const userSources = (Deno.env.get(\"MARKET_SOURCES\") ?? \"\")\n .split(\",\").map((s) => s.trim()).filter(Boolean);\n\n let hits: DiscoveryHit[] = [];\n if (userSources.length > 0) {\n // Direct public pages provided by the operator.\n for (const url of userSources.slice(0, QUERY_LIMIT)) {\n try {\n const text = await fetchPageText(url);\n if (text) hits.push({ url, title: url, snippet: text, source: \"direct\", fetchedAt: new Date().toISOString() });\n } catch {\n /* continue */\n }\n }\n } else {\n const queries = buildQueries();\n const seenUrl = new Set();\n for (const q of queries) {\n if (queriesRun >= QUERY_LIMIT) break;\n queriesRun++;\n try {\n const results = await searchWeb(q);\n for (const h of results) {\n if (seenUrl.has(h.url)) continue;\n seenUrl.add(h.url);\n hits.push(h);\n }\n } catch (e) {\n console.warn(`[hunter] query failed \"${q}\": ${(e as Error).message}`);\n }\n // Small politeness delay between queries.\n await new Promise((r) => setTimeout(r, 250));\n }\n }\n hitsSeen = hits.length;\n console.log(`[hunter] discovered ${hitsSeen} public hits from ${queriesRun} queries`);\n\n // 2) Cheap client-side pre-filter: keep hits that name a target product so we\n // cut unrelated pages before paying for Gemini. Genuine *intent* is judged\n // by Gemini (a substring intent-gate proved too aggressive and dropped\n // real buyers), so we do NOT hard-filter on intent words here.\n const relevant = hits.filter((h) =>\n PRODUCT_CATEGORIES.some((p) =>\n `${h.title} ${h.snippet}`.toLowerCase().includes(p),\n ),\n );\n console.log(`[hunter] ${relevant.length} hits mention a target product (→ Gemini)`);\n\n // 3) Two-layer discovery + qualification.\n type QualifiedOp = RawOpportunity & { evidence_url?: string; source_name?: string; discovery_method: string };\n const BATCH = 14;\n let bingCandidates = 0;\n let groundCandidates = 0;\n let ops: QualifiedOp[] = [];\n\n const qualify = (each: RawOpportunity, method: \"bing\" | \"gemini_google_search\") => {\n const whyLow = (each.intent_score ?? 0) > 0 && (each.intent_score ?? 0) < MIN_INTENT;\n if (!each?.requirement || (each.intent_score ?? 0) <= 0 || whyLow) {\n rejected++;\n console.warn(\n `[hunter] reject ${method} | score=${each.intent_score ?? 0} | req=<${(each.requirement ?? \"\").slice(0, 80)}> | reason=${each.reject_reason ?? (whyLow ? \"low intent\" : \"no purchasing intent\")}`,\n );\n return;\n }\n if (method === \"bing\") bingCandidates++;\n else groundCandidates++;\n ops.push({\n ...each,\n source_name: each.source ?? (method === \"bing\" ? \"bing\" : \"google\"),\n discovery_method: method,\n evidence_url: each.evidence_url ?? \"\",\n });\n };\n\n // LAYER 1 — Bing discovery (pages fetched in step 1) -> Gemini qualification.\n for (let i = 0; i < relevant.length; i += BATCH) {\n const batch = relevant.slice(i, i + BATCH);\n try {\n const parsed = await geminiJson<{ opportunities?: RawOpportunity[] }>(\n buildOpportunityPrompt(batch),\n );\n for (const each of parsed?.opportunities ?? []) qualify(each, \"bing\");\n } catch (e) {\n console.warn(`[hunter] gemini batch failed: ${(e as Error).message}`);\n }\n await new Promise((r) => setTimeout(r, 200));\n }\n\n // LAYER 2 — Gemini Live Google-Search grounding.\n // Opt-in: requires a Gemini plan whose quota permits the google_search tool and\n // a val run with a higher timeout. Enabled via GEMINI_SEARCH_ENABLED=true.\n const groundEnabled = Deno.env.get(\"GEMINI_SEARCH_ENABLED\") === \"true\";\n if (groundEnabled) {\n for (const q of GEMINI_SEARCH_QUERIES.slice(0, Number(Deno.env.get(\"GROUND_QUERY_LIMIT\") ?? 8))) {\n try {\n const { opportunities, sources } = await geminiGroundSearch(q, 2);\n for (const o of opportunities) {\n qualify(\n {\n buyer_name: o.buyer_name ?? null,\n company: o.company ?? null,\n phone: o.public_phone ?? o.phone ?? null,\n email: o.public_email ?? o.email ?? null,\n requirement: o.requirement ?? \"\",\n location: o.location ?? null,\n intent_score: o.intent_score ?? null,\n confidence: o.confidence ?? null,\n outreach: o.outreach ?? null,\n reject_reason: o.reject_reason ?? null,\n evidence_snippet: o.evidence ?? null,\n source: \"google\",\n evidence_url: o.source_url ?? sources[0]?.uri ?? \"\",\n },\n \"gemini_google_search\",\n );\n }\n } catch (e) {\n console.warn(`[hunter] gemini-search query failed \"${q}\": ${(e as Error).message}`);\n }\n await new Promise((r) => setTimeout(r, 400));\n }\n } else {\n console.log(\"[hunter] gemini google-search grounding DISABLED (set GEMINI_SEARCH_ENABLED=true to enable)\");\n }\n candidates = ops.length;\n console.log(`[hunter] layered candidates: bing=${bingCandidates}, gemini_google_search=${groundCandidates}, total=${candidates}`);\n\n // 4) Store with dedup.\n const topLeads: LeadRow[] = [];\n for (const op of ops) {\n const eUrl = op.evidence_url ?? \"\";\n const loc = op.location ?? null;\n const dk = await dedupeKey(eUrl, op.requirement, loc ?? \"\");\n const category = classifyProduct(op.requirement, op.evidence_snippet ?? \"\");\n const value = op.opportunity_value?.amount ?? null;\n const cur = op.opportunity_value?.currency ?? \"NGN\";\n const outreach = op.outreach ?? null;\n // WhatsApp deep link ONLY when a valid public buyer phone number exists.\n const wa = op.phone\n ? buildWhatsAppLink(op.phone, outreach ?? defaultOutreach(op.requirement, loc))\n : null;\n\n const existing = (await sqlite.execute(\n \"SELECT id FROM leads WHERE dedupe_key = ?\",\n [dk],\n )).rows.length;\n\n if (existing > 0) {\n duplicates++;\n await sqlite.execute({\n sql: \"UPDATE leads SET last_seen_at = CURRENT_TIMESTAMP, updated_at = CURRENT_TIMESTAMP WHERE dedupe_key = ?\",\n args: [dk],\n });\n continue;\n }\n\n await sqlite.execute({\n sql: `INSERT INTO leads\n (dedupe_key, buyer_name, company, phone, email, requirement, location,\n product_category, evidence_url, source, evidence_snippet, intent_score,\n opportunity_value, value_currency, confidence, status, whatsapp_link, outreach, discovery_method)\n VALUES (?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,'new',?,?,?)`,\n args: [\n dk, op.buyer_name ?? null, op.company ?? null, op.phone ?? null,\n op.email ?? null, op.requirement, loc, category, eUrl,\n op.source_name ?? \"web\", op.evidence_snippet ?? null,\n Math.round(Number(op.intent_score ?? 0)), value, cur,\n op.confidence ?? null, wa, outreach, op.discovery_method ?? \"bing\",\n ],\n });\n newLeads++;\n }\n\n topLeads.push(...(await listLeads({ limit: 10, order: \"intent_score\" })));\n\n await sqlite.execute({\n sql: `UPDATE hunts SET finished_at=?, status='success', queries_run=?, hits_seen=?,\n candidates=?, new_leads=?, duplicates=?, rejected=? WHERE id=?`,\n args: [\n new Date().toISOString(), queriesRun, hitsSeen, candidates,\n newLeads, duplicates, rejected, huntId,\n ],\n });\n\n const result: HuntResult = fin({ status: \"success\", topLeads });\n console.log(\n `[hunter] HUNT complete: ${newLeads} new, ${duplicates} dups, ${rejected} rejected`,\n );\n return result;\n } catch (e) {\n const msg = (e as Error).message;\n if (huntId !== null) {\n await sqlite.execute({\n sql: \"UPDATE hunts SET finished_at=?, status='error', error=? WHERE id=?\",\n args: [new Date().toISOString(), msg, huntId],\n }).catch(() => {});\n }\n console.error(`[hunter] HUNT error: ${msg}`);\n return fin({ status: \"error\", error: msg });\n }\n}\n\n// --------------------------------------------------------------------------\n// Query helpers for the dashboard / API\n// --------------------------------------------------------------------------\nexport interface LeadFilter {\n status?: string;\n location?: string;\n q?: string;\n limit?: number;\n order?: string;\n}\n\nexport async function listLeads(f: LeadFilter = {}): Promise {\n const conds: string[] = [];\n const args: string[] = [];\n if (f.status && f.status !== \"all\") { conds.push(\"status = ?\"); args.push(f.status); }\n if (f.location) { conds.push(\"location LIKE ?\"); args.push(`%${f.location}%`); }\n if (f.q) {\n conds.push(\"(requirement LIKE ? OR company LIKE ? OR buyer_name LIKE ? OR evidence_snippet LIKE ?)\");\n const like = `%${f.q}%`;\n args.push(like, like, like, like);\n }\n const where = conds.length ? `WHERE ${conds.join(\" AND \")}` : \"\";\n const orderBy = f.order === \"intent_score\" ? \"intent_score DESC, id DESC\" : \"last_seen_at DESC, id DESC\";\n const r = await sqlite.execute(\n `SELECT * FROM leads ${where} ORDER BY ${orderBy} LIMIT ?`,\n [...args, String(f.limit ?? 100)],\n );\n return (r.rows as unknown as Record[]).map((x) => ({\n ...toLead(x),\n }));\n}\n\nexport async function getLead(id: number): Promise {\n const r = await sqlite.execute(\"SELECT * FROM leads WHERE id = ?\", [String(id)]);\n if (!r.rows.length) return null;\n return toLead(r.rows[0] as Record);\n}\n\nexport async function setLeadStatus(id: number, status: string): Promise {\n await sqlite.execute({\n sql: \"UPDATE leads SET status = ?, updated_at = CURRENT_TIMESTAMP WHERE id = ?\",\n args: [status, String(id)],\n });\n}\n\nexport async function listHunts(limit = 12): Promise[]> {\n const r = await sqlite.execute(\n \"SELECT * FROM hunts ORDER BY id DESC LIMIT ?\",\n [String(limit)],\n );\n return r.rows as unknown as Record[];\n}\n\nexport async function stats(): Promise> {\n const total = (await sqlite.execute(\"SELECT COUNT(*) AS n FROM leads\"));\n const tc = total.rows[0] as Record;\n const byStatus = (await sqlite.execute(\n \"SELECT status, COUNT(*) AS n FROM leads GROUP BY status\",\n ));\n const byLocation = (await sqlite.execute(\n \"SELECT COALESCE(location,'unknown') AS location, COUNT(*) AS n FROM leads GROUP BY location ORDER BY n DESC LIMIT 8\",\n ));\n const latestHunt = (await sqlite.execute(\n \"SELECT * FROM hunts ORDER BY id DESC LIMIT 1\",\n )).rows[0] ?? null;\n\n const statusMap: Record = {};\n for (const row of byStatus.rows as Record[]) {\n statusMap[String(row.status)] = Number(row.n);\n }\n const locationMap: Record = {};\n for (const row of byLocation.rows as Record[]) {\n locationMap[String(row.location)] = Number(row.n);\n }\n\n return {\n totalLeads: Number(tc.n),\n byStatus: statusMap,\n byLocation: locationMap,\n latestHunt: latestHunt ?? null,\n businessWhatsApp: `https://wa.me/${BUSINESS_WHATSAPP}`,\n website: WEBSITE,\n configured: { gemini: Boolean(Deno.env.get(\"GEMINI_API_KEY\")) },\n };\n}\n\nfunction toLead(x: Record): LeadRow {\n return {\n id: Number(x.id),\n buyer_name: (x.buyer_name as string) ?? null,\n company: (x.company as string) ?? null,\n phone: (x.phone as string) ?? null,\n email: (x.email as string) ?? null,\n requirement: String(x.requirement ?? \"\"),\n location: (x.location as string) ?? null,\n product_category: (x.product_category as string) ?? null,\n evidence_url: String(x.evidence_url ?? \"\"),\n source: (x.source as string) ?? null,\n evidence_snippet: (x.evidence_snippet as string) ?? null,\n intent_score: x.intent_score == null ? null : Number(x.intent_score),\n opportunity_value: x.opportunity_value == null ? null : Number(x.opportunity_value),\n value_currency: (x.value_currency as string) ?? null,\n confidence: x.confidence == null ? null : Number(x.confidence),\n status: String(x.status ?? \"new\"),\n whatsapp_link: (x.whatsapp_link as string) ?? null,\n outreach: (x.outreach as string) ?? null,\n discovery_method: (x.discovery_method as string) ?? null,\n first_seen_at: String(x.first_seen_at ?? \"\"),\n last_seen_at: String(x.last_seen_at ?? \"\"),\n };\n}\nexport async function health(): Promise> {\n const last = (await sqlite.execute(\n \"SELECT * FROM hunts ORDER BY id DESC LIMIT 1\",\n )).rows[0] as Record | undefined;\n const lastSuccess = (await sqlite.execute(\n \"SELECT * FROM hunts WHERE status='success' ORDER BY id DESC LIMIT 1\",\n )).rows[0] as Record | undefined;\n\n const hasKey = Boolean(Deno.env.get(\"GEMINI_API_KEY\"));\n const le = lastSuccess as (Record & {\n new_leads?: number;\n candidates?: number;\n hits_seen?: number;\n error?: string | null;\n id?: number;\n started_at?: string;\n }) | undefined;\n\n return {\n gemini: hasKey\n ? (le && le.candidates && le.candidates > 0 ? \"CONNECTED\" : \"CONNECTED (key set)\")\n : \"ERROR\",\n discovery: le && le.hits_seen && le.hits_seen > 0 ? \"WORKING\" : (le ? \"WORKING\" : \"ERROR\"),\n qualification: hasKey\n ? (le && (le.candidates ?? 0) > 0 ? \"WORKING\" : \"WORKING (no qualifying leads on last run)\")\n : \"ERROR\",\n database: \"WORKING\",\n cron: \"ACTIVE\",\n schedule: \"0 */4 * * *\",\n lastSuccessfulHunt: le\n ? { id: le.id, startedAt: le.started_at, newLeads: le.new_leads ?? 0, candidates: le.candidates ?? 0, hits: le.hits_seen ?? 0 }\n : null,\n lastHuntError: last?.status === \"error\" ? last.error : null,\n };\n}\n","// lib/hunter.ts\n// Market Hunt orchestrator: discovery -> Gemini qualification/scoring -> storage.\n// Stores qualified leads in the val's scoped SQLite DB with deduplication, hunt\n// history, and per-lead WhatsApp outreach deep links to IS-REAL's business line.\n\nimport { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\nimport {\n buildNigerianBuyerQueries,\n buyerSegments,\n buildQueries,\n crawlSourceUrl,\n DiscoveryHit,\n fetchPageText,\n hasBuyerIntent,\n PRODUCT_CATEGORIES,\n searchWeb,\n} from \"./sources.ts\";\nimport {\n buildOpportunityPrompt,\n geminiJson,\n geminiGroundSearch,\n GEMINI_SEARCH_QUERIES,\n RawOpportunity,\n} from \"./gemini.ts\";\nimport { getHunterSettings, listSources, HunterSettings } from \"./config.ts\";\n\nexport const BUSINESS_WHATSAPP = \"2349160726032\";\nexport const WEBSITE = \"https://is-real-modern-furniture-gr29qv.v2.appdeploy.ai/\";\n\nconst MIN_INTENT = Number(Deno.env.get(\"MIN_INTENT_SCORE\") ?? 50);\nconst QUERY_LIMIT = Number(Deno.env.get(\"QUERY_LIMIT\") ?? 60);\n\n// --------------------------------------------------------------------------\n// Schema\n// --------------------------------------------------------------------------\nawait sqlite.execute(`CREATE TABLE IF NOT EXISTS leads (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n dedupe_key TEXT UNIQUE NOT NULL,\n buyer_name TEXT,\n company TEXT,\n phone TEXT,\n email TEXT,\n requirement TEXT NOT NULL,\n location TEXT,\n product_category TEXT,\n evidence_url TEXT NOT NULL,\n source TEXT,\n evidence_snippet TEXT,\n intent_score INTEGER,\n opportunity_value REAL,\n value_currency TEXT,\n confidence REAL,\n status TEXT DEFAULT 'new',\n whatsapp_link TEXT,\n outreach TEXT,\n discovery_method TEXT,\n first_seen_at TEXT DEFAULT CURRENT_TIMESTAMP,\n last_seen_at TEXT DEFAULT CURRENT_TIMESTAMP,\n updated_at TEXT DEFAULT CURRENT_TIMESTAMP\n)`);\n\n// Migration: add columns introduced after the table first shipped.\ntry { await sqlite.execute(`ALTER TABLE leads ADD COLUMN outreach TEXT`); } catch { /* already exists */ }\ntry { await sqlite.execute(`ALTER TABLE leads ADD COLUMN discovery_method TEXT`); } catch { /* already exists */ }\n\nawait sqlite.execute(`CREATE TABLE IF NOT EXISTS hunts (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n triggered_by TEXT DEFAULT 'cron',\n started_at TEXT,\n finished_at TEXT,\n status TEXT,\n queries_run INTEGER,\n hits_seen INTEGER,\n candidates INTEGER,\n new_leads INTEGER,\n duplicates INTEGER,\n rejected INTEGER,\n error TEXT\n)`);\n\n// --------------------------------------------------------------------------\n// Types\n// --------------------------------------------------------------------------\nexport interface LeadRow {\n id: number;\n buyer_name: string | null;\n company: string | null;\n phone: string | null;\n email: string | null;\n requirement: string;\n location: string | null;\n product_category: string | null;\n evidence_url: string;\n source: string | null;\n evidence_snippet: string | null;\n intent_score: number | null;\n opportunity_value: number | null;\n value_currency: string | null;\n confidence: number | null;\n status: string;\n whatsapp_link: string | null;\n outreach: string | null;\n discovery_method: string | null;\n first_seen_at: string;\n last_seen_at: string;\n}\n\nexport interface HuntResult {\n ok: boolean;\n huntId: number | null;\n triggeredBy: string;\n startedAt: string;\n finishedAt: string;\n status: string;\n queriesRun: number;\n hitsSeen: number;\n candidates: number;\n newLeads: number;\n duplicates: number;\n rejected: number;\n topLeads: LeadRow[];\n error?: string;\n}\n\n// --------------------------------------------------------------------------\n// Helpers\n// --------------------------------------------------------------------------\nasync function sha256(input: string): Promise {\n const data = new TextEncoder().encode(input);\n const digest = await crypto.subtle.digest(\"SHA-256\", data);\n return Array.from(new Uint8Array(digest))\n .map((b) => b.toString(16).padStart(2, \"0\"))\n .join(\"\");\n}\n\nexport async function dedupeKey(evidenceUrl: string, requirement: string, location: string): Promise {\n return sha256(\n `${evidenceUrl.trim().toLowerCase()}::${requirement.trim().toLowerCase()}::${(location ?? \"\").trim().toLowerCase()}`,\n );\n}\n\nfunction classifyProduct(requirement: string, evidence: string): string | null {\n const hay = `${requirement} ${evidence}`.toLowerCase();\n for (const cat of PRODUCT_CATEGORIES) {\n if (hay.includes(cat)) return cat;\n }\n return null;\n}\n\n/** Normalize a phone to the E.164 international form used by wa.me. Returns null\n * if it doesn't look like a valid phone number (never fabricates one). */\nexport function normalizePhone(p: string | null | undefined): string | null {\n if (!p) return null;\n let d = p.replace(/[^\\d]/g, \"\");\n if (d.length === 11 && d.startsWith(\"0\")) d = \"234\" + d.slice(1); // Nigerian 0NN...\n else if (d.length === 10 && d.startsWith(\"0\")) d = \"234\" + d.slice(1);\n else if (d.startsWith(\"+\")) d = d.slice(1);\n if (d.length < 10 || d.length > 15) return null;\n return d;\n}\n\n/** Build a wa.me deep link to the BUYER's phone with a pre-filled outreach message.\n * Only returns a link when a valid buyer phone number exists. */\nexport function buildWhatsAppLink(buyerPhone: string, message: string): string | null {\n const norm = normalizePhone(buyerPhone);\n if (!norm) return null;\n return `https://wa.me/${norm}?text=${encodeURIComponent(message)}`;\n}\n\nexport function businessWhatsApp(): string {\n return `https://wa.me/${BUSINESS_WHATSAPP}`;\n}\n\nfunction defaultOutreach(requirement: string, loc: string | null): string {\n return (\n `Hello, I'm from IS-REAL Modern Furniture (${WEBSITE}). I saw you are looking for ` +\n `\"${requirement}\"${loc ? ` in ${loc}` : \"\"}. We design and supply quality modern ` +\n `furniture in Nigeria. May I send you our catalogue and a quote?`\n );\n}\n\n// --------------------------------------------------------------------------\n// The hunt\n// --------------------------------------------------------------------------\nexport async function runHunt(options?: { source?: string }): Promise {\n const startedAt = new Date().toISOString();\n const triggeredBy = options?.source ?? \"manual\";\n let huntId: number | null = null;\n\n const fin = (\n partial: Partial & { status: string },\n ): HuntResult => {\n return {\n ok: partial.status === \"success\",\n huntId,\n triggeredBy,\n startedAt,\n finishedAt: new Date().toISOString(),\n queriesRun: partial.queriesRun ?? queriesRun,\n hitsSeen: partial.hitsSeen ?? hitsSeen,\n candidates: partial.candidates ?? candidates,\n newLeads: partial.newLeads ?? newLeads,\n duplicates: partial.duplicates ?? duplicates,\n rejected: partial.rejected ?? rejected,\n topLeads: partial.topLeads ?? [],\n status: partial.status,\n error: partial.error,\n };\n };\n\n let queriesRun = 0;\n let hitsSeen = 0;\n let candidates = 0;\n let newLeads = 0;\n let duplicates = 0;\n let rejected = 0;\n\n try {\n await sqlite.execute({\n sql: `INSERT INTO hunts (triggered_by, started_at, status) VALUES (?, ?, 'running')`,\n args: [triggeredBy, startedAt],\n });\n const r = (await sqlite.execute(\n \"SELECT last_insert_rowid() AS id\",\n ));\n const row = r.rows[0] as Record;\n huntId = Number(row.id);\n\n // 1) Discover evidence.\n const userSources = (Deno.env.get(\"MARKET_SOURCES\") ?? \"\")\n .split(\",\").map((s) => s.trim()).filter(Boolean);\n\n let hits: DiscoveryHit[] = [];\n if (userSources.length > 0) {\n // Direct public pages provided by the operator.\n for (const url of userSources.slice(0, QUERY_LIMIT)) {\n try {\n const text = await fetchPageText(url);\n if (text) hits.push({ url, title: url, snippet: text, source: \"direct\", fetchedAt: new Date().toISOString() });\n } catch {\n /* continue */\n }\n }\n } else {\n const queries = buildQueries();\n const seenUrl = new Set();\n for (const q of queries) {\n if (queriesRun >= QUERY_LIMIT) break;\n queriesRun++;\n try {\n const results = await searchWeb(q);\n for (const h of results) {\n if (seenUrl.has(h.url)) continue;\n seenUrl.add(h.url);\n hits.push(h);\n }\n } catch (e) {\n console.warn(`[hunter] query failed \"${q}\": ${(e as Error).message}`);\n }\n // Small politeness delay between queries.\n await new Promise((r) => setTimeout(r, 250));\n }\n }\n hitsSeen = hits.length;\n console.log(`[hunter] discovered ${hitsSeen} public hits from ${queriesRun} queries`);\n\n // 2) Cheap client-side pre-filter: keep hits that name a target product so we\n // cut unrelated pages before paying for Gemini. Genuine *intent* is judged\n // by Gemini (a substring intent-gate proved too aggressive and dropped\n // real buyers), so we do NOT hard-filter on intent words here.\n const relevant = hits.filter((h) =>\n PRODUCT_CATEGORIES.some((p) =>\n `${h.title} ${h.snippet}`.toLowerCase().includes(p),\n ),\n );\n console.log(`[hunter] ${relevant.length} hits mention a target product (→ Gemini)`);\n\n // 3) Two-layer discovery + qualification.\n type QualifiedOp = RawOpportunity & { evidence_url?: string; source_name?: string; discovery_method: string };\n const BATCH = 14;\n let bingCandidates = 0;\n let groundCandidates = 0;\n let ops: QualifiedOp[] = [];\n\n const qualify = (each: RawOpportunity, method: \"bing\" | \"gemini_google_search\") => {\n const whyLow = (each.intent_score ?? 0) > 0 && (each.intent_score ?? 0) < MIN_INTENT;\n if (!each?.requirement || (each.intent_score ?? 0) <= 0 || whyLow) {\n rejected++;\n console.warn(\n `[hunter] reject ${method} | score=${each.intent_score ?? 0} | req=<${(each.requirement ?? \"\").slice(0, 80)}> | reason=${each.reject_reason ?? (whyLow ? \"low intent\" : \"no purchasing intent\")}`,\n );\n return;\n }\n if (method === \"bing\") bingCandidates++;\n else groundCandidates++;\n ops.push({\n ...each,\n source_name: each.source ?? (method === \"bing\" ? \"bing\" : \"google\"),\n discovery_method: method,\n evidence_url: each.evidence_url ?? \"\",\n });\n };\n\n // LAYER 1 — Bing discovery (pages fetched in step 1) -> Gemini qualification.\n for (let i = 0; i < relevant.length; i += BATCH) {\n const batch = relevant.slice(i, i + BATCH);\n try {\n const parsed = await geminiJson<{ opportunities?: RawOpportunity[] }>(\n buildOpportunityPrompt(batch),\n );\n for (const each of parsed?.opportunities ?? []) qualify(each, \"bing\");\n } catch (e) {\n console.warn(`[hunter] gemini batch failed: ${(e as Error).message}`);\n }\n await new Promise((r) => setTimeout(r, 200));\n }\n\n // LAYER 2 — Gemini Live Google-Search grounding.\n // Opt-in: requires a Gemini plan whose quota permits the google_search tool and\n // a val run with a higher timeout. Enabled via GEMINI_SEARCH_ENABLED=true.\n const groundEnabled = Deno.env.get(\"GEMINI_SEARCH_ENABLED\") === \"true\";\n if (groundEnabled) {\n for (const q of GEMINI_SEARCH_QUERIES.slice(0, Number(Deno.env.get(\"GROUND_QUERY_LIMIT\") ?? 8))) {\n try {\n const { opportunities, sources } = await geminiGroundSearch(q, 2);\n for (const o of opportunities) {\n qualify(\n {\n buyer_name: o.buyer_name ?? null,\n company: o.company ?? null,\n phone: o.public_phone ?? o.phone ?? null,\n email: o.public_email ?? o.email ?? null,\n requirement: o.requirement ?? \"\",\n location: o.location ?? null,\n intent_score: o.intent_score ?? null,\n confidence: o.confidence ?? null,\n outreach: o.outreach ?? null,\n reject_reason: o.reject_reason ?? null,\n evidence_snippet: o.evidence ?? null,\n source: \"google\",\n evidence_url: o.source_url ?? sources[0]?.uri ?? \"\",\n },\n \"gemini_google_search\",\n );\n }\n } catch (e) {\n console.warn(`[hunter] gemini-search query failed \"${q}\": ${(e as Error).message}`);\n }\n await new Promise((r) => setTimeout(r, 400));\n }\n } else {\n console.log(\"[hunter] gemini google-search grounding DISABLED (set GEMINI_SEARCH_ENABLED=true to enable)\");\n }\n candidates = ops.length;\n console.log(`[hunter] layered candidates: bing=${bingCandidates}, gemini_google_search=${groundCandidates}, total=${candidates}`);\n\n // 4) Store with dedup.\n const topLeads: LeadRow[] = [];\n for (const op of ops) {\n const eUrl = op.evidence_url ?? \"\";\n const loc = op.location ?? null;\n const dk = await dedupeKey(eUrl, op.requirement, loc ?? \"\");\n const category = classifyProduct(op.requirement, op.evidence_snippet ?? \"\");\n const value = op.opportunity_value?.amount ?? null;\n const cur = op.opportunity_value?.currency ?? \"NGN\";\n const outreach = op.outreach ?? null;\n // WhatsApp deep link ONLY when a valid public buyer phone number exists.\n const wa = op.phone\n ? buildWhatsAppLink(op.phone, outreach ?? defaultOutreach(op.requirement, loc))\n : null;\n\n const existing = (await sqlite.execute(\n \"SELECT id FROM leads WHERE dedupe_key = ?\",\n [dk],\n )).rows.length;\n\n if (existing > 0) {\n duplicates++;\n await sqlite.execute({\n sql: \"UPDATE leads SET last_seen_at = CURRENT_TIMESTAMP, updated_at = CURRENT_TIMESTAMP WHERE dedupe_key = ?\",\n args: [dk],\n });\n continue;\n }\n\n await sqlite.execute({\n sql: `INSERT INTO leads\n (dedupe_key, buyer_name, company, phone, email, requirement, location,\n product_category, evidence_url, source, evidence_snippet, intent_score,\n opportunity_value, value_currency, confidence, status, whatsapp_link, outreach, discovery_method)\n VALUES (?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,'new',?,?,?)`,\n args: [\n dk, op.buyer_name ?? null, op.company ?? null, op.phone ?? null,\n op.email ?? null, op.requirement, loc, category, eUrl,\n op.source_name ?? \"web\", op.evidence_snippet ?? null,\n Math.round(Number(op.intent_score ?? 0)), value, cur,\n op.confidence ?? null, wa, outreach, op.discovery_method ?? \"bing\",\n ],\n });\n newLeads++;\n }\n\n topLeads.push(...(await listLeads({ limit: 10, order: \"intent_score\" })));\n\n await sqlite.execute({\n sql: `UPDATE hunts SET finished_at=?, status='success', queries_run=?, hits_seen=?,\n candidates=?, new_leads=?, duplicates=?, rejected=? WHERE id=?`,\n args: [\n new Date().toISOString(), queriesRun, hitsSeen, candidates,\n newLeads, duplicates, rejected, huntId,\n ],\n });\n\n const result: HuntResult = fin({ status: \"success\", topLeads });\n console.log(\n `[hunter] HUNT complete: ${newLeads} new, ${duplicates} dups, ${rejected} rejected`,\n );\n return result;\n } catch (e) {\n const msg = (e as Error).message;\n if (huntId !== null) {\n await sqlite.execute({\n sql: \"UPDATE hunts SET finished_at=?, status='error', error=? WHERE id=?\",\n args: [new Date().toISOString(), msg, huntId],\n }).catch(() => {});\n }\n console.error(`[hunter] HUNT error: ${msg}`);\n return fin({ status: \"error\", error: msg });\n }\n}\n\n// --------------------------------------------------------------------------\n// Query helpers for the dashboard / API\n// --------------------------------------------------------------------------\nexport interface LeadFilter {\n status?: string;\n location?: string;\n q?: string;\n limit?: number;\n order?: string;\n}\n\nexport async function listLeads(f: LeadFilter = {}): Promise {\n const conds: string[] = [];\n const args: string[] = [];\n if (f.status && f.status !== \"all\") { conds.push(\"status = ?\"); args.push(f.status); }\n if (f.location) { conds.push(\"location LIKE ?\"); args.push(`%${f.location}%`); }\n if (f.q) {\n conds.push(\"(requirement LIKE ? OR company LIKE ? OR buyer_name LIKE ? OR evidence_snippet LIKE ?)\");\n const like = `%${f.q}%`;\n args.push(like, like, like, like);\n }\n const where = conds.length ? `WHERE ${conds.join(\" AND \")}` : \"\";\n const orderBy = f.order === \"intent_score\" ? \"intent_score DESC, id DESC\" : \"last_seen_at DESC, id DESC\";\n const r = await sqlite.execute(\n `SELECT * FROM leads ${where} ORDER BY ${orderBy} LIMIT ?`,\n [...args, String(f.limit ?? 100)],\n );\n return (r.rows as unknown as Record[]).map((x) => ({\n ...toLead(x),\n }));\n}\n\nexport async function getLead(id: number): Promise {\n const r = await sqlite.execute(\"SELECT * FROM leads WHERE id = ?\", [String(id)]);\n if (!r.rows.length) return null;\n return toLead(r.rows[0] as Record);\n}\n\nexport async function setLeadStatus(id: number, status: string): Promise {\n await sqlite.execute({\n sql: \"UPDATE leads SET status = ?, updated_at = CURRENT_TIMESTAMP WHERE id = ?\",\n args: [status, String(id)],\n });\n}\n\nexport async function listHunts(limit = 12): Promise[]> {\n const r = await sqlite.execute(\n \"SELECT * FROM hunts ORDER BY id DESC LIMIT ?\",\n [String(limit)],\n );\n return r.rows as unknown as Record[];\n}\n\nexport async function stats(): Promise> {\n const total = (await sqlite.execute(\"SELECT COUNT(*) AS n FROM leads\"));\n const tc = total.rows[0] as Record;\n const byStatus = (await sqlite.execute(\n \"SELECT status, COUNT(*) AS n FROM leads GROUP BY status\",\n ));\n const byLocation = (await sqlite.execute(\n \"SELECT COALESCE(location,'unknown') AS location, COUNT(*) AS n FROM leads GROUP BY location ORDER BY n DESC LIMIT 8\",\n ));\n const latestHunt = (await sqlite.execute(\n \"SELECT * FROM hunts ORDER BY id DESC LIMIT 1\",\n )).rows[0] ?? null;\n\n const statusMap: Record = {};\n for (const row of byStatus.rows as Record[]) {\n statusMap[String(row.status)] = Number(row.n);\n }\n const locationMap: Record = {};\n for (const row of byLocation.rows as Record[]) {\n locationMap[String(row.location)] = Number(row.n);\n }\n\n return {\n totalLeads: Number(tc.n),\n byStatus: statusMap,\n byLocation: locationMap,\n latestHunt: latestHunt ?? null,\n businessWhatsApp: `https://wa.me/${BUSINESS_WHATSAPP}`,\n website: WEBSITE,\n configured: { gemini: Boolean(Deno.env.get(\"GEMINI_API_KEY\")) },\n };\n}\n\nfunction toLead(x: Record): LeadRow {\n return {\n id: Number(x.id),\n buyer_name: (x.buyer_name as string) ?? null,\n company: (x.company as string) ?? null,\n phone: (x.phone as string) ?? null,\n email: (x.email as string) ?? null,\n requirement: String(x.requirement ?? \"\"),\n location: (x.location as string) ?? null,\n product_category: (x.product_category as string) ?? null,\n evidence_url: String(x.evidence_url ?? \"\"),\n source: (x.source as string) ?? null,\n evidence_snippet: (x.evidence_snippet as string) ?? null,\n intent_score: x.intent_score == null ? null : Number(x.intent_score),\n opportunity_value: x.opportunity_value == null ? null : Number(x.opportunity_value),\n value_currency: (x.value_currency as string) ?? null,\n confidence: x.confidence == null ? null : Number(x.confidence),\n status: String(x.status ?? \"new\"),\n whatsapp_link: (x.whatsapp_link as string) ?? null,\n outreach: (x.outreach as string) ?? null,\n discovery_method: (x.discovery_method as string) ?? null,\n first_seen_at: String(x.first_seen_at ?? \"\"),\n last_seen_at: String(x.last_seen_at ?? \"\"),\n };\n}\nexport async function health(): Promise> {\n const last = (await sqlite.execute(\n \"SELECT * FROM hunts ORDER BY id DESC LIMIT 1\",\n )).rows[0] as Record | undefined;\n const lastSuccess = (await sqlite.execute(\n \"SELECT * FROM hunts WHERE status='success' ORDER BY id DESC LIMIT 1\",\n )).rows[0] as Record | undefined;\n\n const hasKey = Boolean(Deno.env.get(\"GEMINI_API_KEY\"));\n const le = lastSuccess as (Record & {\n new_leads?: number;\n candidates?: number;\n hits_seen?: number;\n error?: string | null;\n id?: number;\n started_at?: string;\n }) | undefined;\n\n return {\n gemini: hasKey\n ? (le && le.candidates && le.candidates > 0 ? \"CONNECTED\" : \"CONNECTED (key set)\")\n : \"ERROR\",\n discovery: le && le.hits_seen && le.hits_seen > 0 ? \"WORKING\" : (le ? \"WORKING\" : \"ERROR\"),\n qualification: hasKey\n ? (le && (le.candidates ?? 0) > 0 ? \"WORKING\" : \"WORKING (no qualifying leads on last run)\")\n : \"ERROR\",\n database: \"WORKING\",\n cron: \"ACTIVE\",\n schedule: \"0 */4 * * *\",\n lastSuccessfulHunt: le\n ? { id: le.id, startedAt: le.started_at, newLeads: le.new_leads ?? 0, candidates: le.candidates ?? 0, hits: le.hits_seen ?? 0 }\n : null,\n lastHuntError: last?.status === \"error\" ? last.error : null,\n };\n}\n","createdAt",["D",1787620665428],"branchVersion","branchId","ac292285-e807-44ad-b932-d224d7a2bc0b","id","062aa035-2622-42e9-b197-d325a6afd62b","is-real-ai-sales-os",["D",1787435303615],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","IS-REAL AI client acquisition and sales automation OS","imageUrl","7f4d7826-53c8-4b3e-9b4f-1e07fc1853e4","pinnedFileId","01a02b72-4343-720e-b974-db3653f8238f","pinPreview",true,"pinMigrated","screenshotVersion","likeCount",0,"orgId","01a02b69-5d30-761f-af3c-cfbcd92a2566","tursoName","062aa035262242e9b197d325a6afd62b","tursoHostname","062aa035262242e9b197d325a6afd62b-val-town.aws-us-east-2.turso.io","tursoMeasuredAt",["D",1789521640046],"pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_107":106,"_115":111},"org",{"_107":106,"_108":109,"_110":111,"_19":62,"_112":113,"_114":31},"branch",{"_13":96,"_38":97,"_50":49,"_98":51,"_99":-5,"_100":-5,"_101":-5,"_102":-5,"_103":-5,"_104":52,"_105":106},"isOwned",112,"main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","isrealmodernfurniture","handle","displayName","IS-REAL Modern furniture","avatar","https://lh3.googleusercontent.com/a/ACg8ocLoG7wn933Ub4ABjB-fo6OOcMHznhw2GQGgVPJAJXagSLjgyeo7=s96-c","tier","free","canRestrictVals","profileImageUrl","branchName","","adoptOrgId",{"_50":51,"_38":52,"_45":267,"_54":-5,"_55":31,"_56":57,"_58":57,"_59":60,"_61":-5,"_19":62,"_63":64,"_65":66,"_67":-5,"_68":-5,"_69":70,"_71":72,"_73":74,"_75":76,"_77":268,"_79":-5,"_80":81,"_82":81,"_83":84,"_85":84,"_86":84,"_87":81,"_88":81,"_89":269,"_91":270,"_93":271,"_95":31},"tree",[201,203,208,209,210,211],"files",[201,202,203,204,205,206,207,208,209,210,211],"counts",{"_190":70,"_191":151,"_192":70,"_193":194,"_195":196},"contents",[138,139,140,141,142,143],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},{"_50":185,"_38":186,"_36":187,"_147":-5,"_48":49,"_47":151,"_149":66,"_45":188,"_13":70,"_40":183,"_42":-5,"_30":31,"_154":-5,"_33":189},{"_50":178,"_38":179,"_36":180,"_147":-5,"_48":49,"_47":181,"_149":66,"_45":182,"_13":70,"_40":183,"_42":-5,"_30":31,"_154":-5,"_33":184},{"_50":172,"_38":173,"_36":174,"_147":-5,"_48":49,"_47":151,"_149":66,"_45":175,"_13":70,"_40":26,"_42":176,"_30":31,"_154":-5,"_33":177},{"_50":165,"_38":166,"_36":167,"_147":-5,"_48":49,"_47":168,"_149":66,"_45":169,"_13":151,"_40":26,"_42":170,"_30":31,"_154":-5,"_33":171},{"_50":156,"_38":157,"_36":64,"_147":-5,"_48":49,"_47":158,"_149":31,"_45":159,"_13":160,"_40":161,"_42":162,"_30":31,"_154":163,"_33":164},{"_50":144,"_38":145,"_36":146,"_147":-5,"_48":49,"_47":148,"_149":31,"_45":150,"_13":151,"_40":152,"_42":153,"_30":31,"_154":-5,"_33":155},"8390c3b5-2799-43b0-8370-0eb3d812b47f","market-hunter.ts","68d53af0-9e73-11f1-9179-1607ee4eb77e","parentId",8,"latest",["D",1787616751409],1,"interval","// market-hunter.ts\n// Scheduled Market Hunt worker (fileType: interval). Runs automatically on the\n// cron schedule. Each execution discovers public furniture-buying evidence in\n// Nigeria, qualifies it with Gemini, stores qualified leads, and logs a clear\n// result. Invoking this file directly (e.g. via run_file) triggers one hunt.\n\nimport { runHunt } from \"./lib/hunter.ts\";\n\nexport default async function (interval: Interval) {\n console.log(\n `[market-hunter] scheduled run started. lastRunAt=${interval.lastRunAt ? interval.lastRunAt.toISOString() : \"(first run)\"}`,\n );\n\n const result = await runHunt({ source: \"cron\" });\n\n // Clear, structured result for the schedule trigger and for logs/observability.\n console.log(\n JSON.stringify({\n market_hunter: \"IS-REAL AI Sales OS\",\n run: result.status,\n ok: result.ok,\n huntId: result.huntId,\n triggeredBy: result.triggeredBy,\n startedAt: result.startedAt,\n finishedAt: result.finishedAt,\n queriesRun: result.queriesRun,\n hitsSeen: result.hitsSeen,\n qualifiedCandidates: result.candidates,\n newLeads: result.newLeads,\n duplicatesDeduped: result.duplicates,\n rejected: result.rejected,\n geminiConfigured: Boolean(Deno.env.get(\"GEMINI_API_KEY\")),\n error: result.error ?? null,\n }),\n );\n\n return result;\n}\n","label",[145],"4c86aab9-6bee-4601-b5c1-7c9d3bdffc47","index.ts",42,["D",1787619380486],7,"http","/** @jsxImportSource npm:hono@4/jsx */\n// index.ts\n// IS-REAL AI Sales OS — Market Hunter HTTP dashboard + API.\n// Serves a live ops dashboard (real SQLite data) and REST endpoints, including a\n// manual \"Run Hunt Now\" trigger. Server-rendered with hono/jsx (no client SPA).\n\nimport { Hono } from \"npm:hono\";\nimport { parseVal } from \"https://esm.town/v/std/utils/index.ts\";\nimport {\n BUSINESS_WHATSAPP,\n businessWhatsApp,\n getLead,\n health,\n listHunts,\n listLeads,\n runHunt,\n setLeadStatus,\n stats,\n WEBSITE,\n} from \"./lib/hunter.ts\";\nimport type { LeadRow } from \"./lib/hunter.ts\";\n\nconst app = new Hono();\n\nconst VALID_STATUSES = [\"new\", \"contacted\", \"quoted\", \"closed\", \"rejected\"] as const;\n\nconst fmt = (n: number | null, cur = \"NGN\") =>\n n == null ? \"—\" : `${cur} ${Number(n).toLocaleString(\"en-NG\")}`;\n\nfunction Badge({ children, tone }: { children: unknown; tone?: string }) {\n const color =\n tone === \"error\"\n ? \"#e74c3c\"\n : tone === \"ok\"\n ? \"#27ae60\"\n : tone === \"warn\"\n ? \"#e67e22\"\n : \"#3498db\";\n return (\n \n {children}\n \n );\n}\n\nfunction Layout({ title, children }: { title: string; children: unknown }) {\n return (\n \n \n \n \n {title}\n

Diff · v59