[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8},"actionData","errors","root",{"_104":105,"_106":107},"routes/embed.x.$handle.$name.$",{"_9":10,"_11":12,"_13":14,"_15":16,"_17":18,"_19":20,"_21":-5},"handle","deepthisudhakar023","name","salonbot","path","heytrill.ts","project",{"_22":45,"_11":12,"_33":46,"_47":-5,"_48":42,"_49":50,"_51":50,"_52":-5,"_53":-5,"_54":55,"_56":57,"_58":32,"_59":-5,"_60":-5,"_61":62,"_63":64,"_65":66,"_67":68,"_69":70,"_71":-5,"_72":73,"_74":73,"_75":76,"_77":76,"_78":76,"_79":73,"_80":73,"_81":82,"_83":84,"_85":86,"_87":42},"file",{"_22":23,"_11":14,"_24":25,"_26":-5,"_27":28,"_29":30,"_31":32,"_33":34,"_35":36,"_37":38,"_39":40,"_41":42,"_43":-5,"_13":44},"permalink","https://www.val.town/x/deepthisudhakar023/salonbot/code/heytrill.ts","extension","id","58785ea8-224e-45c4-a247-a05b5060cbf9","fileId","cc5c8056-acfb-11f1-a254-1607ee4eb77e","parentId","branchId","4d6f32cf-d725-4d74-8cf9-91088c8e84e4","branchVersion",56,"latest",true,"createdAt",["D",1789219089991],"version",24,"fileType","http","content","// HeyTrill AI Assistant - WhatsApp bot on Meta Cloud API.\n// Answers questions about HeyTrill's three services (websites, WhatsApp AI assistant, AI visibility), pricing, setup process,\n// books free audits (lead capture), hands off to Deepthi when needed.\n// Architecture: Groq AI layer (conversation + intent parse, never writes state)\n// on deterministic rails (lead capture, owner alerts). Meta webhook plumbing.\nimport { sqlite } from \"https://esm.town/v/std/sqlite\";\nimport { email } from \"https://esm.town/v/std/email\";\n\nconst VERIFY_TOKEN = Deno.env.get(\"VERIFY_TOKEN\") ?? \"heytrill-verify-dev\";\nconst IG_ACCESS_TOKEN = Deno.env.get(\"IG_ACCESS_TOKEN\") ?? \"\";\nconst IG_USER_ID = Deno.env.get(\"IG_USER_ID\") ?? \"17841425565466394\";\nconst PHONE_NUMBER_ID = Deno.env.get(\"PHONE_NUMBER_ID\") ?? \"\";\nconst META_TOKEN = Deno.env.get(\"META_TOKEN\") ?? \"\";\nconst OWNER_NOTE = \"HeyTrill bot\";\n\nconst pick = (arr: T[]): T => arr[Math.floor(Math.random() * arr.length)];\n\nconst greetingMsg = (name?: string) => {\n const hiL = name ? `hey ${name}!` : pick([\"hey!\", \"hey there!\", \"hi!\"]);\n return pick([\n `${hiL} you've reached HeyTrill 👋 we build websites, WhatsApp AI assistants, and we get businesses named by ChatGPT. what's on your mind?`,\n `${hiL} this is HeyTrill - we do three things: websites, WhatsApp bots that answer your customers 24/7, and AI search visibility. what can i help with?`,\n ]);\n};\n\nconst HANDOFF_MSG = pick([\n `that one's a bit outside what i can answer - Deepthi (our founder) will reply right here shortly. anything else i can help with meanwhile? 😊`,\n `good question - that one's for Deepthi, our founder. she'll reply here shortly. can i help with anything else in the meantime?`,\n]);\n\nconst confirmLeadAsk = (name: string, biz: string, interest: string) =>\n `just to confirm, ${name}: you want *${interest}* for *${biz}*. i'll have Deepthi reach out ${interest === \"a website\" ? \"to discuss your project\" : \"to set up your free audit\"}. shall i go ahead?`;\n\nconst leadDone = (name: string) =>\n pick([\n `done, ${name} - you're on the list 🎉 Deepthi will message you here within a day to set up the free audit. anything else you want to know meanwhile?`,\n `all set, ${name} ✅ Deepthi will reach out here within a day about the free audit. ask me anything else in the meantime`,\n ]);\n\nconst leadDropped = `no worries, dropped it. anything else i can help with?`;\nconst confirmNudge = `just reply yes to confirm, or no to drop it`;\n\n// ---------------- knowledge base + AI layer ----------------\nconst AI_PREFIX = `You are the WhatsApp assistant at HeyTrill, texting with prospective clients. You sound like a real person at a small, sharp agency - warm, relaxed, plain-spoken. Answer ONLY from this real company data:`;\nconst KB_FALLBACK = `ABOUT HEYTRILL:\n- HeyTrill is an AI services company founded by Deepthi Sudhakar. Three services, sold worldwide: (1) websites, (2) WhatsApp AI assistant, (3) AI search visibility (GEO).\n- We do NOT build careers pages or ATS products. If asked about those, say that's not something we do and steer back to the three services.\n- Team: fully remote, no public office - works with clients worldwide. If asked where you are based or where the office is, say exactly that.\n- Brand: \"hey\" is the first word of every customer conversation, and a trill is the bird call that carries above the noise - \"when a customer says hey, you're always heard\".\n\nSERVICE 1 - Websites:\n- Done-for-you business websites and landing pages, built end to end - the client never touches anything technical. Often bundled with enquiry handling and the WhatsApp bot.\n- Pricing: quoted per project by Deepthi - there is no standard website price, do not quote one. If asked, say websites are custom-quoted after a quick chat about what's needed, and offer to have Deepthi reach out.\n\nSERVICE 2 - WhatsApp AI Assistant:\n- A bot on the business's OWN WhatsApp number that answers customers instantly, 24/7: shares services and prices, takes bookings, answers questions in the customer's language, and hands over to a human when needed.\n- Includes the Sunday Brief: a weekly WhatsApp digest for the owner - bookings, missed messages, top customer questions, dead hours.\n- No app, no software to install - just WhatsApp. Fully done-for-you setup, takes about a week. The business owner never touches anything technical - we need a number not currently on WhatsApp and one verification code.\n- Pricing: founding-client offer Rs.9,999 one-time setup + Rs.3,999/month (first 5 clients). Standard rate Rs.19,999 setup + Rs.3,999/month.\n- The client keeps their own WhatsApp for themselves; the bot runs on its own number.\n\nSERVICE 3 - AI Search Visibility (GEO):\n- Getting the business named when buyers ask ChatGPT, Gemini or Perplexity what to buy. Like SEO, but for AI answers.\n- Starts with a one-off AI-visibility audit: 30-50 real buyer prompts run across the major AI tools, showing exactly where the business shows up, where it's invisible, and the specific content moves that flip it. Audit: Rs.20,000 one-off.\n- Ongoing retainer after the audit: Rs.45,000/month for the full visibility program.\n- Hook: a growing share of buyers now start at ChatGPT instead of Google. Every AI answer that names a rival is a shortlist the business never made.\n\nPROCESS FOR PROSPECTS:\n- Next step is a FREE audit / demo. For GEO it is a short, free sample visibility check on a handful of real buyer prompts - NOT the full 30-50 prompt paid audit. For the bot it is a walkthrough of a working assistant demo. Then a custom proposal.\n- If asked how the free audit works: Deepthi runs a few real buyer searches for their business on the AI tools, shows them where they show up and where they're invisible, and talks through what it would take to fix it. Never describe the free audit as the full 30-50 prompt audit - that one is the paid Rs.20,000 product. The bot (you) collects the prospect's name, business name, and which service they're interested in, and Deepthi reaches out on WhatsApp within a day.\n- Payment and contracts are handled by Deepthi directly - you never discuss payment methods, invoices, or contracts.`;\nconst AI_RULES = `STRICT RULES:\n1. Never invent a price, discount, feature, timeline, or policy. For OFF-TOPIC stuff (they ask about products we don't sell, the weather, homework, jokes, spam): answer briefly that this is HeyTrill's business line and what we do, then move on - do NOT hand off. HANDOFF (exactly one word) only when a real prospect asks something about working with us that the data above doesn't cover (custom builds, integrations, contracts, negotiation).\n2. Questions about the two services, pricing, what's included, how setup works, timelines, and the free audit ARE answerable from the data - answer them, do not hand off.\n3. Reply in the SAME language the customer writes in: English, Hindi, Kannada, Hinglish, or any mix. If they ask in romanized Kannada/Hindi (or ask you to reply in a language), reply in that language's NATIVE script. Default English only when they write in English.\n4. VOICE - this matters most: you text like a friendly human assistant, not a form. Short casual messages. Lowercase is your default - sentences start lowercase, \"i\" not \"I\", relaxed punctuation. Plain words, zero corporate speak: no \"assist\", \"regarding\", \"kindly\", \"please note\", \"feel free\". Say \"hey\" not \"Dear customer\". Warm and direct. NEVER use stock enthusiasm or AI cliches: no \"Great choice\", \"Certainly\", \"I'd be happy to\", \"Absolutely!\", \"Happy to help\", \"Great question\". Don't end every message with a question.\n5. Emojis: sprinkle naturally - maybe 1 in 2-3 messages, where a real person would put one (😊 👋 🎉 😅). Never more than one per message, never in serious/pricing answers.\n6. Keep replies SHORT - 1 to 4 sentences, like a real WhatsApp message. If the answer needs structure (like a price breakdown), a short list is fine. Prices can keep normal formatting (₹9,999) - numbers stay clear.\n7. Use the chat history - you remember this whole conversation and past chats with this person. If they refer to something earlier (\"that one\", \"the audit\", \"and the bot?\"), answer with that context instead of asking again. If you know their name, use it once in a while, not every message.\n8. Small talk and pleasantries (\"how are you\", \"thanks\", \"ok\", \"nice\", \"bye\") are NOT handoffs: answer briefly like a real person, then steer back to how we can help.\n9. If they ask who you are: you're HeyTrill's AI assistant - say so plainly, it's fine. Then point out this is literally service 1 in action.\n10. Never discuss competitors' pricing, never bad-mouth other agencies or tools. If asked to compare, describe what HeyTrill does and let it speak for itself.\n11. Never share Deepthi's personal number, email, or any internal detail. The contact path is this chat.\n12. Do not commit to discounts beyond the founding offer, custom quotes, or specific delivery dates beyond \"about a week\". Those go to Deepthi: reply HANDOFF.\n12b. The rupee prices are the India rate card. If the prospect is clearly outside India or asks about dollars/international pricing: say international pricing is quoted separately and Deepthi will share it - do not convert or invent a dollar figure.\n13. HANDOFF only when someone explicitly wants to TALK to a human, speak with Deepthi, or get on a call - or when rules 1/12 require it. Questions ABOUT Deepthi (who she is, her role) are answerable from the data above - answer them, do not hand off.`;\n\n// ---------------- Google Sheet bridge (knowledge is LIVE from the sheet; falls back to KB_FALLBACK) ----------------\nconst SHEET_BRIDGE = Deno.env.get(\"SHEET_BRIDGE_URL\") || \"\";\nconst SHEET_SECRET = Deno.env.get(\"SHEET_SECRET\") || \"\";\nlet sheetCache: { at: number; map: Record } | null = null;\nasync function sheetKnowledge(): Promise | null> {\n if (!SHEET_BRIDGE) return null;\n if (sheetCache && Date.now() - sheetCache.at < 45_000) return sheetCache.map;\n try {\n const res = await fetch(`${SHEET_BRIDGE}?op=read&secret=${encodeURIComponent(SHEET_SECRET)}`);\n if (!res.ok) return sheetCache ? sheetCache.map : null;\n const j = await res.json();\n if (!j || typeof j.knowledge !== \"object\") return sheetCache ? sheetCache.map : null;\n sheetCache = { at: Date.now(), map: j.knowledge };\n return sheetCache.map;\n } catch { return sheetCache ? sheetCache.map : null; }\n}\nasync function sheetAppend(tab: string, row: (string | number)[]) {\n if (!SHEET_BRIDGE) return;\n try {\n await fetch(SHEET_BRIDGE, { method: \"POST\", headers: { \"Content-Type\": \"application/json\" }, body: JSON.stringify({ secret: SHEET_SECRET, op: \"append\", tab, row }) });\n } catch {}\n}\nasync function buildSystem(): Promise {\n const m = await sheetKnowledge();\n const kb = m\n ? [\"ABOUT HEYTRILL:\", m[\"section:about\"] || \"\", \"\", \"SERVICE 1 - Websites:\", m[\"section:websites\"] || \"\", \"\", \"SERVICE 2 - WhatsApp AI Assistant:\", m[\"section:assistant\"] || \"\", \"\", \"SERVICE 3 - AI Search Visibility (GEO):\", m[\"section:visibility\"] || \"\", \"\", \"PROCESS FOR PROSPECTS:\", m[\"section:process\"] || \"\"].join(\"\\n\")\n : KB_FALLBACK;\n return AI_PREFIX + \"\\n\\n\" + kb + \"\\n\\n\" + AI_RULES;\n}\nasync function ownerCfg(): Promise<{ email: string; wa: string }> {\n const m = await sheetKnowledge();\n return { email: (m && m[\"config:owner_alert_email\"]) || OWNER_EMAIL, wa: (m && m[\"config:owner_whatsapp\"]) || OWNER_WA };\n}\n\n\nasync function aiReply(userText: string, history: { role: string; text: string }[], facts: string = \"\"): Promise {\n const key = Deno.env.get(\"GROQ_API_KEY\");\n if (!key) return null;\n try {\n const ctrl = new AbortController();\n const timer = setTimeout(() => ctrl.abort(), 12000);\n const res = await fetch(\"https://api.groq.com/openai/v1/chat/completions\", {\n method: \"POST\",\n headers: {\n \"Authorization\": `Bearer ${key}`,\n \"Content-Type\": \"application/json\",\n },\n body: JSON.stringify({\n model: \"openai/gpt-oss-120b\",\n reasoning_effort: \"low\",\n temperature: 0.3,\n max_completion_tokens: 400,\n messages: [\n { role: \"system\", content: (await buildSystem()) + (facts ? \"\\n\\nREMEMBERED ABOUT THIS CUSTOMER (use naturally, never recite): \" + facts : \"\") },\n ...history.map((h) => ({ role: h.role === \"user\" ? \"user\" : \"assistant\", content: h.text })),\n { role: \"user\", content: userText },\n ],\n }),\n signal: ctrl.signal,\n });\n clearTimeout(timer);\n if (!res.ok) { lastAiStatus = \"http \" + res.status; return null; }\n const j = await res.json();\n let txt = String(j?.choices?.[0]?.message?.content || \"\").trim();\n txt = txt.replace(/\\*\\*/g, \"*\");\n if (!txt) lastAiStatus = \"empty content\";\n return txt || null;\n } catch (e) {\n lastAiStatus = \"err \" + String(e).slice(0, 80);\n return null;\n }\n}\n\nconst VALID_INTENTS = [\"book\", \"query\", \"greeting\", \"smalltalk\", \"handoff\", \"vischeck\", \"other\"];\nconst VALID_INTERESTS = [\"assistant\", \"visibility\", \"website\", \"both\"];\n\nasync function parseMessage(userText: string, history: { role: string; text: string }[]): Promise<{ intent: string; name: string | null; business: string | null; interest: string | null; category?: string | null; city?: string | null } | null> {\n const key = Deno.env.get(\"GROQ_API_KEY\");\n if (!key) return null;\n const system = `You are the intent parser for HeyTrill's WhatsApp assistant. Extract intent from the prospect's message. They may write in English, Hindi, Kannada, or any mix, in native or romanized script. Reply with ONLY a JSON object, no markdown:\n{\"intent\":\"book|query|greeting|smalltalk|handoff|vischeck|other\",\"name\":\"first name|null\",\"business\":\"business name|null\",\"interest\":\"assistant|visibility|website|both|null\",\"category\":\"what the business sells|null\",\"city\":\"city or market|null\"}\n\n- intent: book = wants the free audit/demo or wants to sign up / take the next step (\"sign me up\", \"book the audit\", \"let's do it\", \"i'm interested, next steps\"). vischeck = wants to TRY the free AI visibility sample check right now (\"check my brand\", \"run the test\", \"do the sample check\", \"see if I show up\"). query = asks a question. greeting = ONLY hi/hello with nothing else. smalltalk = social chit-chat with no request. handoff = explicitly asks for a human / Deepthi / a call. other = anything else.\n- category: what the business sells/does (e.g. \"dental clinic\", \"cloud kitchen\") if stated in this message or recent chat. null if absent.\n- city: the business's city or market if stated in this message or recent chat. null if absent.\n- name: the prospect's first name if they introduce themselves in this message OR clearly stated earlier in the recent chat. Otherwise null.\n- business: their business name if stated in this message OR clearly stated earlier in the recent chat. Otherwise null.\n- interest: assistant = the WhatsApp AI assistant/bot. visibility = AI search visibility/GEO/ChatGPT ranking. website = a website/landing page build. both = multiple services. null if unclear.\n- Use recent chat context to resolve references, but extract the intent of the NEW message only.\n- Only extract what the message actually says. Use null when absent.`;\n try {\n const ctrl = new AbortController();\n const timer = setTimeout(() => ctrl.abort(), 8000);\n const res = await fetch(\"https://api.groq.com/openai/v1/chat/completions\", {\n method: \"POST\",\n headers: {\n \"Authorization\": `Bearer ${key}`,\n \"Content-Type\": \"application/json\",\n },\n body: JSON.stringify({\n model: \"openai/gpt-oss-120b\",\n reasoning_effort: \"low\",\n temperature: 0,\n max_completion_tokens: 350,\n messages: [\n { role: \"system\", content: system },\n { role: \"user\", content: history.length ? \"Recent chat:\\n\" + history.map((h) => (h.role === \"user\" ? \"Prospect\" : \"Bot\") + \": \" + h.text).join(\"\\n\") + \"\\n\\nProspect's new message: \" + userText : userText },\n ],\n }),\n signal: ctrl.signal,\n });\n clearTimeout(timer);\n if (!res.ok) {\n lastAiStatus = \"http \" + res.status;\n if (res.status === 429) {\n await new Promise((r) => setTimeout(r, 2000));\n return parseMessage(userText, history);\n }\n return null;\n }\n const j = await res.json();\n const txt = String(j?.choices?.[0]?.message?.content || \"\");\n const m = txt.match(/\\{[\\s\\S]*\\}/);\n if (!m) return null;\n const p = JSON.parse(m[0]);\n return {\n intent: VALID_INTENTS.includes(p.intent) ? p.intent : \"other\",\n name: typeof p.name === \"string\" && /^[A-Za-z][A-Za-z.' -]{1,29}$/.test(p.name.trim()) ? p.name.trim() : null,\n business: typeof p.business === \"string\" && p.business.trim().length >= 2 && p.business.trim().length <= 60 ? p.business.trim() : null,\n interest: VALID_INTERESTS.includes(p.interest) ? p.interest : null,\n category: typeof p.category === \"string\" && p.category.trim().length >= 2 && p.category.trim().length <= 60 ? p.category.trim() : null,\n city: typeof p.city === \"string\" && p.city.trim().length >= 2 && p.city.trim().length <= 40 ? p.city.trim() : null,\n };\n } catch (_e) {\n return null;\n }\n}\n\n// ---------------- storage ----------------\nlet tableReady = false;\nasync function ensureTables() {\n if (tableReady) return;\n await sqlite.execute(`CREATE TABLE IF NOT EXISTS ht_sessions (wa_id TEXT PRIMARY KEY, step TEXT, name TEXT, business TEXT, interest TEXT, updated_at INTEGER)`);\n await sqlite.execute(`CREATE TABLE IF NOT EXISTS ht_history (wa_id TEXT, role TEXT, text TEXT, ts INTEGER)`);\n await sqlite.execute(`CREATE TABLE IF NOT EXISTS ht_leads (id TEXT PRIMARY KEY, wa_id TEXT, name TEXT, business TEXT, interest TEXT, ts INTEGER)`);\n await sqlite.execute(`CREATE TABLE IF NOT EXISTS ht_processed (msg_id TEXT PRIMARY KEY, ts INTEGER)`);\n await sqlite.execute(`CREATE TABLE IF NOT EXISTS ht_outbox (id INTEGER PRIMARY KEY AUTOINCREMENT, wa_id TEXT, text TEXT, ts INTEGER)`);\n await sqlite.execute(`CREATE TABLE IF NOT EXISTS ht_vis_ctx (wa_id TEXT PRIMARY KEY, category TEXT, city TEXT)`);\n await sqlite.execute(`CREATE TABLE IF NOT EXISTS ht_memory (wa_id TEXT PRIMARY KEY, summary TEXT, covers INTEGER, updated_at INTEGER)`);\n await sqlite.execute(`CREATE TABLE IF NOT EXISTS ht_vis (id INTEGER PRIMARY KEY AUTOINCREMENT, wa_id TEXT, business TEXT, result TEXT, ts INTEGER)`);\n tableReady = true;\n}\nasync function getSession(wa: string) {\n await ensureTables();\n const r = await sqlite.execute({ sql: `SELECT step, name, business, interest FROM ht_sessions WHERE wa_id = ?`, args: [wa] });\n if (r.rows && r.rows.length) return { step: String(r.rows[0][0]), name: String(r.rows[0][1] || \"\"), business: String(r.rows[0][2] || \"\"), interest: String(r.rows[0][3] || \"\") };\n return { step: \"new\", name: \"\", business: \"\", interest: \"\" };\n}\nasync function setSession(wa: string, step: string, name: string, business: string, interest: string) {\n await ensureTables();\n await sqlite.execute({\n sql: `INSERT INTO ht_sessions (wa_id, step, name, business, interest, updated_at) VALUES (?, ?, ?, ?, ?, ?)\n ON CONFLICT(wa_id) DO UPDATE SET step=excluded.step, name=excluded.name, business=excluded.business, interest=excluded.interest, updated_at=excluded.updated_at`,\n args: [wa, step, name, business, interest, Date.now()],\n });\n}\nasync function getMemory(wa: string): Promise {\n try {\n const r = await sqlite.execute({ sql: `SELECT summary FROM ht_memory WHERE wa_id = ?`, args: [wa] });\n return String(r.rows[0]?.summary || \"\");\n } catch (_e) { return \"\"; }\n}\n// Rolling summary of the older chat, so the bot remembers the WHOLE conversation, not just recent messages.\nasync function maybeSummarize(wa: string): Promise {\n const key = Deno.env.get(\"GROQ_API_KEY\");\n if (!key) return;\n try {\n const cnt = Number((await sqlite.execute({ sql: `SELECT COUNT(*) AS c FROM ht_history WHERE wa_id = ?`, args: [wa] })).rows[0]?.c || 0);\n if (cnt <= 70) return;\n const mem = await sqlite.execute({ sql: `SELECT summary, covers FROM ht_memory WHERE wa_id = ?`, args: [wa] });\n const prevSummary = String(mem.rows[0]?.summary || \"\");\n const covered = Number(mem.rows[0]?.covers || 0);\n const boundary = cnt - 50; // last 50 stay verbatim-only\n if (boundary - covered < 15) return; // summarize in chunks of ~15+ old messages\n const rows = await sqlite.execute({ sql: `SELECT role, text FROM ht_history WHERE wa_id = ? ORDER BY ts ASC LIMIT ? OFFSET ?`, args: [wa, boundary - covered, covered] });\n const chunk = rows.rows.map((r) => (String(r.role) === \"user\" ? \"Customer\" : \"Bot\") + \": \" + String(r.text)).join(\"\\n\");\n const res = await fetch(\"https://api.groq.com/openai/v1/chat/completions\", {\n method: \"POST\",\n headers: { \"Authorization\": `Bearer ${key}`, \"Content-Type\": \"application/json\" },\n body: JSON.stringify({\n model: \"openai/gpt-oss-120b\",\n reasoning_effort: \"low\",\n temperature: 0.2,\n max_completion_tokens: 500,\n messages: [\n { role: \"system\", content: \"You compress a WhatsApp sales chat into a running memory note for the bot. Update the existing note with the new messages. Keep: customer facts (name, business, city, budget, contact details), what they asked, what the bot promised or quoted (exact prices), decisions made, open questions, and the customer's tone/language. Drop filler. Max 200 words, plain telegraphic English.\" },\n { role: \"user\", content: \"EXISTING NOTE:\\n\" + (prevSummary || \"(none)\") + \"\\n\\nNEW MESSAGES TO FOLD IN:\\n\" + chunk },\n ],\n }),\n });\n if (!res.ok) return;\n const j = await res.json();\n const sum = String(j?.choices?.[0]?.message?.content || \"\").trim();\n if (!sum) return;\n await sqlite.execute({\n sql: `INSERT INTO ht_memory (wa_id, summary, covers, updated_at) VALUES (?, ?, ?, ?)\n ON CONFLICT(wa_id) DO UPDATE SET summary = excluded.summary, covers = excluded.covers, updated_at = excluded.updated_at`,\n args: [wa, sum.slice(0, 2000), boundary, Date.now()],\n });\n } catch (_e) { /* best effort - memory failure never breaks the chat */ }\n}\n\nasync function addHistory(wa: string, role: string, text: string) {\n await ensureTables();\n await sqlite.execute({ sql: `INSERT INTO ht_history (wa_id, role, text, ts) VALUES (?, ?, ?, ?)`, args: [wa, role, text.slice(0, 1000), Date.now()] });\n await sqlite.execute({ sql: `DELETE FROM ht_history WHERE wa_id = ? AND ts NOT IN (SELECT ts FROM ht_history WHERE wa_id = ? ORDER BY ts DESC LIMIT 5000)`, args: [wa, wa] });\n}\nasync function getHistory(wa: string): Promise<{ role: string; text: string }[]> {\n await ensureTables();\n const r = await sqlite.execute({ sql: `SELECT role, text FROM ht_history WHERE wa_id = ? ORDER BY ts DESC LIMIT 60`, args: [wa] });\n return (r.rows || []).reverse().map((row) => ({ role: String(row[0]), text: String(row[1]) }));\n}\nasync function alreadyProcessed(id: string): Promise {\n await ensureTables();\n const r = await sqlite.execute({ sql: `SELECT 1 FROM ht_processed WHERE msg_id = ?`, args: [id] });\n return !!(r.rows && r.rows.length);\n}\nasync function markProcessed(id: string) {\n await ensureTables();\n await sqlite.execute({ sql: `INSERT OR IGNORE INTO ht_processed (msg_id, ts) VALUES (?, ?)`, args: [id, Date.now()] });\n}\nfunction leadId(): string {\n const chars = \"ABCDEFGHJKMNPQRSTUVWXYZ23456789\";\n let s = \"\";\n for (let i = 0; i < 4; i++) s += chars[Math.floor(Math.random() * chars.length)];\n return \"HT-\" + s;\n}\n\nasync function getVisCtx(wa: string): Promise<{ category: string; city: string }> {\n await ensureTables();\n const r = await sqlite.execute({ sql: `SELECT category, city FROM ht_vis_ctx WHERE wa_id = ?`, args: [wa] });\n if (r.rows && r.rows.length) return { category: String(r.rows[0][0] || \"\"), city: String(r.rows[0][1] || \"\") };\n return { category: \"\", city: \"\" };\n}\nasync function setVisCtx(wa: string, category: string, city: string) {\n await ensureTables();\n await sqlite.execute({ sql: `INSERT INTO ht_vis_ctx (wa_id, category, city) VALUES (?, ?, ?) ON CONFLICT(wa_id) DO UPDATE SET category=excluded.category, city=excluded.city`, args: [wa, category, city] });\n}\n\nasync function groqRaw(system: string, user: string, temp: number, maxTokens: number, timeoutMs: number): Promise {\n const key = Deno.env.get(\"GROQ_API_KEY\");\n if (!key) return null;\n for (let attempt = 0; attempt < 2; attempt++) {\n try {\n const ctrl = new AbortController();\n const timer = setTimeout(() => ctrl.abort(), timeoutMs);\n const res = await fetch(\"https://api.groq.com/openai/v1/chat/completions\", {\n method: \"POST\",\n headers: { \"Authorization\": `Bearer ${key}`, \"Content-Type\": \"application/json\" },\n body: JSON.stringify({\n model: \"openai/gpt-oss-120b\",\n reasoning_effort: \"low\",\n temperature: temp,\n max_completion_tokens: maxTokens,\n messages: [{ role: \"system\", content: system }, { role: \"user\", content: user }],\n }),\n signal: ctrl.signal,\n });\n clearTimeout(timer);\n if (!res.ok) { lastAiStatus = \"http \" + res.status; if (res.status === 429) { await new Promise((r) => setTimeout(r, 2000)); continue; } return null; }\n const j = await res.json();\n return String(j?.choices?.[0]?.message?.content || \"\").trim() || null;\n } catch (_e) { return null; }\n }\n return null;\n}\n\nasync function groqModel(model: string, user: string, timeoutMs: number): Promise {\n const key = Deno.env.get(\"GROQ_API_KEY\");\n if (!key) return null;\n try {\n const ctrl = new AbortController();\n const timer = setTimeout(() => ctrl.abort(), timeoutMs);\n const res = await fetch(\"https://api.groq.com/openai/v1/chat/completions\", {\n method: \"POST\",\n headers: { \"Authorization\": `Bearer ${key}`, \"Content-Type\": \"application/json\" },\n body: JSON.stringify({\n model,\n reasoning_effort: \"low\",\n temperature: 0.7,\n max_completion_tokens: 260,\n messages: [{ role: \"system\", content: \"You are a helpful assistant giving buying recommendations. Answer in 2-4 sentences, naming specific businesses when you can.\" }, { role: \"user\", content: user }],\n }),\n signal: ctrl.signal,\n });\n clearTimeout(timer);\n if (!res.ok) { lastAiStatus = \"http \" + res.status; return null; }\n const j = await res.json();\n return String(j?.choices?.[0]?.message?.content || \"\").trim() || null;\n } catch (_e) { return null; }\n}\n\nconst norm = (s: string) => s.toLowerCase().replace(/[^a-z0-9 ]/g, \" \").replace(/\\s+/g, \" \").trim();\nfunction brandMentioned(business: string, answer: string): boolean {\n const a = norm(answer);\n const b = norm(business);\n if (!b) return false;\n if (a.includes(b)) return true;\n const toks = b.split(\" \").filter((t) => t.length >= 3 && ![\"the\", \"and\", \"for\", \"of\"].includes(t));\n return toks.length > 0 && toks.every((t) => a.includes(t));\n}\n\nasync function runVisFlow(wa: string, name: string, business: string, category: string, city: string) {\n await ensureTables();\n // one free check per number per 20h\n const recent = await sqlite.execute({ sql: `SELECT result FROM ht_vis WHERE wa_id = ? AND ts > ? ORDER BY ts DESC LIMIT 1`, args: [wa, Date.now() - 20 * 3600 * 1000] });\n if (recent.rows && recent.rows.length) {\n const again = `i ran a sample check for *${business}* recently, so won't burn another one - results won't have moved yet. the real next step is the full audit: 30-50 buyer prompts across ChatGPT, Gemini and Perplexity, with the exact content moves to get you named. ₹20,000 one-off, Deepthi walks you through it. want me to have her reach out?`;\n await setSession(wa, \"confirm_lead\", name, business, \"visibility\");\n await addHistory(wa, \"assistant\", again);\n await sendWhatsApp(wa, again);\n lastPath = \"vis_ratelimit\";\n return;\n }\n const interim = pick([`on it - running a quick sample check on *${business}* now. give me ~30 seconds ⏳`, `running the sample check on *${business}* now - about 30 seconds ⏳`]);\n await addHistory(wa, \"assistant\", interim);\n await sendWhatsApp(wa, interim);\n\n const where = city ? ` in ${city}` : \"\";\n const raw = await groqRaw(\n \"You write buyer research prompts. Return ONLY a JSON array of 5 strings, no markdown.\",\n `Write 5 short questions a real buyer would type into an AI assistant (like ChatGPT) when looking for a ${category}${where}. Vary them: best-of, recommendation request, price/quality comparison, specific need, near-me style. Output the JSON array only.`,\n 0.7, 350, 12000);\n let prompts: string[] = [];\n try {\n const m = (raw || \"\").match(/\\[[\\s\\S]*\\]/);\n if (m) prompts = (JSON.parse(m[0]) as unknown[]).filter((s) => typeof s === \"string\").slice(0, 5) as string[];\n } catch (_e) { /* fall through */ }\n if (prompts.length < 3) {\n const sorry = `hmm, my sample checker is having a moment - don't want to give you half a result 😅 Deepthi can run it for you manually today instead. want me to have her reach out?`;\n await setSession(wa, \"confirm_lead\", name, business, \"visibility\");\n await addHistory(wa, \"assistant\", sorry);\n await sendWhatsApp(wa, sorry);\n lastPath = \"vis_failed\";\n return;\n }\n\n const engines = [\n { model: \"openai/gpt-oss-120b\", label: \"Model A\" },\n { model: \"qwen/qwen3.8-27b\", label: \"Model B\" },\n ];\n const perEngine: { label: string; hits: number; answers: string[] }[] = [];\n for (const eng of engines) {\n const answers: (string | null)[] = [];\n for (let i = 0; i < prompts.length; i += 2) {\n const batch = await Promise.all(prompts.slice(i, i + 2).map(async (p) => {\n let a = await groqModel(eng.model, p, 15000);\n if (!a) { await new Promise((r) => setTimeout(r, 1500)); a = await groqModel(eng.model, p, 15000); }\n return a;\n }));\n answers.push(...batch);\n await new Promise((r) => setTimeout(r, 800));\n }\n const ok = answers.filter((a): a is string => !!a);\n perEngine.push({ label: eng.label, hits: ok.filter((a) => brandMentioned(business, a)).length, answers: ok });\n }\n if (perEngine.every((e) => e.answers.length === 0)) {\n const sorry = `hmm, my sample checker is having a moment - don't want to give you half a result 😅 Deepthi can run it for you manually today instead. want me to have her reach out?`;\n await setSession(wa, \"confirm_lead\", name, business, \"visibility\");\n await addHistory(wa, \"assistant\", sorry);\n await sendWhatsApp(wa, sorry);\n lastPath = \"vis_failed\";\n return;\n }\n\n // rival extraction: one cheap call over all answers\n let rivalsLine = \"\";\n const joined = perEngine.flatMap((e) => e.answers).join(\"\\n---\\n\").slice(0, 6000);\n const rraw = await groqRaw(\"Extract business/brand names. Return ONLY a JSON array of strings, no markdown.\", `Text:\\n${joined}\\n\\nList every business or brand name mentioned in the text above. JSON array only.`, 0, 200, 10000);\n try {\n const m = (rraw || \"\").match(/\\[[\\s\\S]*\\]/);\n if (m) {\n const names = (JSON.parse(m[0]) as unknown[]).filter((s): s is string => typeof s === \"string\");\n const own = norm(business);\n const uniq: string[] = [];\n for (const n of names) {\n const nn = n.trim();\n if (nn && !norm(nn).includes(own) && !own.includes(norm(nn)) && !uniq.some((u) => norm(u) === norm(nn))) uniq.push(nn);\n }\n if (uniq.length) rivalsLine = `\\nRivals getting named instead: ${uniq.slice(0, 4).join(\", \")}.`;\n }\n } catch (_e) { /* optional */ }\n\n const n = prompts.length;\n const live = perEngine.filter((e) => e.answers.length > 0);\n const [eA, eB] = live;\n const totalAns = live.reduce((s, e) => s + e.answers.length, 0);\n const verdict = live.every((e) => e.hits === 0)\n ? `*${business}* didn't come up in any of the ${totalAns} answers - you're invisible to AI buyers right now 😬`\n : live.length === 2\n ? `*${business}* came up in ${eA.hits} of ${eA.answers.length} answers on one model and ${eB.hits} of ${eB.answers.length} on the other.`\n : `*${business}* came up in ${eA.hits} of ${eA.answers.length} answers.`;\n const modelsWord = live.length === 2 ? \"2 different AI models\" : \"an AI model\";\n const result = `sample check done! ran ${n} real buyer questions through ${modelsWord}.\\n\\n${verdict}${rivalsLine}\\n\\nThat's a small sample - the full AI-visibility audit runs 30-50 prompts across ChatGPT, Gemini and Perplexity and hands you the exact content moves to get named. Rs.20,000 one-off, Deepthi walks you through it personally.\\n\\n${name ? `Want me to have her reach out, ${name}? Just say yes.` : `Want in? Just tell me your name and I'll have Deepthi reach out.`}`;\n await sqlite.execute({ sql: `INSERT INTO ht_vis (wa_id, business, result, ts) VALUES (?, ?, ?, ?)`, args: [wa, business, live.map((e) => `${e.label}:${e.hits}/${e.answers.length}`).join(\" \"), Date.now()] });\n await setSession(wa, name ? \"confirm_lead\" : \"collecting\", name, business, \"visibility\");\n await addHistory(wa, \"assistant\", result);\n await sendWhatsApp(wa, result);\n lastPath = \"vis_done\";\n}\n\n// ---------------- Meta send ----------------\nasync function sendInstagram(igsid: string, text: string) {\n await ensureTables();\n if (!IG_ACCESS_TOKEN) {\n await sqlite.execute({ sql: `INSERT INTO ht_outbox (wa_id, text, ts) VALUES (?, ?, ?)`, args: [\"ig:\" + igsid, text, Date.now()] });\n return;\n }\n try {\n const res = await fetch(`https://graph.instagram.com/v21.0/me/messages`, {\n method: \"POST\",\n headers: { \"Authorization\": `Bearer ${IG_ACCESS_TOKEN}`, \"Content-Type\": \"application/json\" },\n body: JSON.stringify({ recipient: { id: igsid }, message: { text: text.slice(0, 1000) } }),\n });\n if (!res.ok) {\n const t = await res.text();\n await sqlite.execute({ sql: `INSERT INTO ht_outbox (wa_id, text, ts) VALUES (?, ?, ?)`, args: [\"ig:\" + igsid, \"IG SEND FAILED: \" + res.status + \" \" + t.slice(0, 150) + \" :: \" + text.slice(0, 150), Date.now()] });\n }\n } catch (_e) { /* best effort */ }\n}\n\nasync function sendWhatsApp(wa: string, text: string) {\n if (wa.startsWith(\"ig:\")) return sendInstagram(wa.slice(3), text);\n await ensureTables();\n sheetAppend(\"chats\", [new Date().toISOString(), \"+\" + wa, \"bot\", text.slice(0, 1500), \"\"]);\n if (!META_TOKEN || !PHONE_NUMBER_ID) {\n await sqlite.execute({ sql: `INSERT INTO ht_outbox (wa_id, text, ts) VALUES (?, ?, ?)`, args: [wa, text, Date.now()] });\n return;\n }\n const res = await fetch(`https://graph.facebook.com/v24.0/${PHONE_NUMBER_ID}/messages`, {\n method: \"POST\",\n headers: { \"Authorization\": `Bearer ${META_TOKEN}`, \"Content-Type\": \"application/json\" },\n body: JSON.stringify({ messaging_product: \"whatsapp\", to: wa, type: \"text\", text: { body: text } }),\n });\n if (!res.ok) {\n await sqlite.execute({ sql: `INSERT INTO ht_outbox (wa_id, text, ts) VALUES (?, ?, ?)`, args: [wa, \"SEND FAILED: \" + res.status + \" :: \" + text.slice(0, 200), Date.now()] });\n }\n}\n\nconst BREVO_KEY = Deno.env.get(\"BREVO_API_KEY\") ?? \"\";\nconst OWNER_EMAIL = \"deepthi@heytrill.com\";\nconst OWNER_WA = \"919900528568\";\n\nasync function alertOwner(subject: string, text: string) {\n const oc = await ownerCfg();\n if (BREVO_KEY) {\n try {\n const res = await fetch(\"https://api.brevo.com/v3/smtp/email\", {\n method: \"POST\",\n headers: { \"api-key\": BREVO_KEY, \"Content-Type\": \"application/json\" },\n body: JSON.stringify({\n sender: { email: oc.email, name: \"HeyTrill bot\" },\n to: [{ email: oc.email }],\n subject: `${OWNER_NOTE}: ${subject}`,\n textContent: text,\n }),\n });\n if (res.ok) return;\n } catch (_e) { /* fall through to std/email */ }\n }\n try {\n await email({ subject: `${OWNER_NOTE}: ${subject}`, text });\n } catch (_e) { /* best effort */ }\n}\n\n// Hot-lead ping to Deepthi's WhatsApp. Freeform works inside a 24h window; outside it\n// Meta rejects until we register a utility template - failures land in the outbox log.\nasync function ownerPing(text: string) {\n if (!META_TOKEN || !PHONE_NUMBER_ID) return;\n const oc = await ownerCfg();\n try {\n const res = await fetch(`https://graph.facebook.com/v24.0/${PHONE_NUMBER_ID}/messages`, {\n method: \"POST\",\n headers: { \"Authorization\": `Bearer ${META_TOKEN}`, \"Content-Type\": \"application/json\" },\n body: JSON.stringify({ messaging_product: \"whatsapp\", to: oc.wa, type: \"text\", text: { body: text.slice(0, 900) } }),\n });\n if (!res.ok) {\n await sqlite.execute({ sql: `INSERT INTO ht_outbox (wa_id, text, ts) VALUES (?, ?, ?)`, args: [OWNER_WA, \"OWNER PING FAILED: \" + res.status + \" :: \" + text.slice(0, 150), Date.now()] });\n }\n } catch (_e) { /* best effort */ }\n}\n\nlet lastPath = \"?\";\nlet lastAiStatus = \"\";\n// ---------------- conversation engine ----------------\nasync function handleMessage(wa: string, bodyRaw: string): Promise {\n const body = bodyRaw.trim();\n if (!body) return;\n const sess = await getSession(wa);\n const history = await getHistory(wa);\n await addHistory(wa, \"user\", body);\n sheetAppend(\"chats\", [new Date().toISOString(), \"+\" + wa, \"customer\", body.slice(0, 1500), \"\"]);\n\n // Pending lead confirmation?\n if (sess.step === \"confirm_lead\" && !sess.name && !/^(n|no|nope|nah|beda|illa|venda|nahi|नहीं|ಬೇಡ|ಇಲ್ಲ)\\b/.test(body.toLowerCase())) {\n // never save a nameless lead: if they seem keen but we lack a name, collect it\n const parsed0 = await parseMessage(body, history);\n const nm = parsed0?.name || \"\";\n if (!nm && /^(y|yes|yeah|yep|haan|ha|hodu|sure|ok|okay|go ahead|sari|ಹೌದು|हाँ|हां)\\b/.test(body.toLowerCase())) {\n const askNm = `sure - what's your name?`;\n await setSession(wa, \"collecting\", \"\", sess.business, sess.interest);\n await addHistory(wa, \"assistant\", askNm);\n await sendWhatsApp(wa, askNm);\n lastPath = \"collecting\";\n return;\n }\n if (nm) await setSession(wa, \"confirm_lead\", nm, sess.business, sess.interest);\n }\n if (sess.step === \"confirm_lead\") {\n if (/^(y|yes|yeah|yep|haan|ha|hodu|sure|ok|okay|go ahead|sari|ಹೌದು|हाँ|हां)\\b/.test(body.toLowerCase())) {\n const fresh = await getSession(wa);\n const id = leadId();\n await sqlite.execute({ sql: `INSERT INTO ht_leads (id, wa_id, name, business, interest, ts) VALUES (?, ?, ?, ?, ?, ?)`, args: [id, wa, fresh.name, fresh.business, fresh.interest, Date.now()] });\n const nowIso = new Date().toISOString();\n sheetAppend(\"leads\", [nowIso, \"+\" + wa, fresh.name || \"\", fresh.business || \"\", fresh.interest || \"\", \"confirm_lead\", id]);\n sheetAppend(\"bookings\", [nowIso, \"+\" + wa, fresh.name || \"\", fresh.business || \"\", fresh.interest || \"\", \"\", \"audit_demo_requested\", id]);\n await alertOwner(`New lead ${id}`, `Name: ${fresh.name}\\nBusiness: ${fresh.business}\\nInterested in: ${fresh.interest}\\nWhatsApp: +${wa}\\nLead ID: ${id}\\n\\nReach out to set up the free audit.`);\n await ownerPing(`🔥 Hot lead ${id}: ${fresh.name} (${fresh.business}) - ${fresh.interest}. WhatsApp: +${wa}`);\n await setSession(wa, \"done\", fresh.name, fresh.business, fresh.interest);\n const reply = leadDone(fresh.name || \"there\");\n lastPath = \"lead_saved\";\n await addHistory(wa, \"assistant\", reply);\n await sendWhatsApp(wa, reply);\n return;\n }\n if (/^(n|no|nope|nah|beda|illa|venda|nahi|नहीं|ಬೇಡ|ಇಲ್ಲ)\\b/.test(body.toLowerCase())) {\n await setSession(wa, \"normal\", sess.name, sess.business, sess.interest);\n lastPath = \"lead_dropped\";\n await addHistory(wa, \"assistant\", leadDropped);\n await sendWhatsApp(wa, leadDropped);\n return;\n }\n // anything else while pending: nudge once, but still try to answer via AI below\n }\n\n const parsed = await parseMessage(body, history);\n const name = parsed?.name || sess.name;\n const business = parsed?.business || sess.business;\n const interest = parsed?.interest || sess.interest;\n if (name !== sess.name || business !== sess.business || interest !== sess.interest) {\n await setSession(wa, sess.step === \"new\" ? \"normal\" : sess.step, name, business, interest);\n }\n\n // Pending visibility-check info collection?\n if (sess.step === \"vis_collect\") {\n const ctx = await getVisCtx(wa);\n const cat = parsed?.category || ctx.category;\n const cty = parsed?.city || ctx.city;\n const biz = parsed?.business || business;\n if (biz) await setSession(wa, \"vis_collect\", name, biz, \"visibility\");\n if (biz && cat) {\n await setVisCtx(wa, cat, cty);\n await setSession(wa, \"normal\", name, biz, \"visibility\");\n await runVisFlow(wa, name, biz, cat, cty);\n return;\n }\n await setVisCtx(wa, cat, cty);\n const ask2 = !biz\n ? `what's the business called, and what do you sell? (city helps too)`\n : `and what does ${biz} sell? a quick line like \"dental clinic\" or \"cloud kitchen\" is enough`;\n await addHistory(wa, \"assistant\", ask2);\n await sendWhatsApp(wa, ask2);\n lastPath = \"vis_collect\";\n return;\n }\n\n // Free sample visibility check requested?\n if (parsed?.intent === \"vischeck\") {\n const cat = parsed?.category || \"\";\n const cty = parsed?.city || \"\";\n const biz = parsed?.business || business;\n if (biz && cat) {\n await setVisCtx(wa, cat, cty);\n await setSession(wa, \"normal\", name, biz, \"visibility\");\n await runVisFlow(wa, name, biz, cat, cty);\n return;\n }\n await setVisCtx(wa, cat, cty);\n await setSession(wa, \"vis_collect\", name, biz, \"visibility\");\n const ask1 = !biz\n ? `happy to! what's the business called, what do you sell, and which city?`\n : `happy to! what does ${biz} sell, and which city? one line is enough`;\n await addHistory(wa, \"assistant\", ask1);\n await sendWhatsApp(wa, ask1);\n lastPath = \"vis_collect\";\n return;\n }\n\n // Booking intent: collect what's missing, then confirm.\n if (parsed?.intent === \"book\") {\n const missing: string[] = [];\n if (!name) missing.push(\"name\");\n if (!business) missing.push(\"business\");\n if (missing.length) {\n const ask = missing.length === 2\n ? `happy to set that up! can i get your name and your business name?`\n : missing[0] === \"name\"\n ? `happy to set that up! what's your name?`\n : `nice - and what's the business called?`;\n await setSession(wa, \"collecting\", name, business, interest || \"both\");\n lastPath = \"collecting\";\n await addHistory(wa, \"assistant\", ask);\n await sendWhatsApp(wa, ask);\n return;\n }\n const intr = interest || \"both\";\n const intrLabel = intr === \"assistant\" ? \"the WhatsApp AI assistant\" : intr === \"visibility\" ? \"AI search visibility\" : intr === \"website\" ? \"a website\" : \"multiple services\";\n const ask = confirmLeadAsk(name, business, intrLabel);\n await setSession(wa, \"confirm_lead\", name, business, intr);\n lastPath = \"confirm_lead\";\n await addHistory(wa, \"assistant\", ask);\n await sendWhatsApp(wa, ask);\n return;\n }\n\n // While collecting, a message that carries the missing info should move us forward.\n if (sess.step === \"collecting\" && name && business) {\n const intr = interest || \"both\";\n const intrLabel = intr === \"assistant\" ? \"the WhatsApp AI assistant\" : intr === \"visibility\" ? \"AI search visibility\" : intr === \"website\" ? \"a website\" : \"multiple services\";\n const ask = confirmLeadAsk(name, business, intrLabel);\n await setSession(wa, \"confirm_lead\", name, business, intr);\n await addHistory(wa, \"assistant\", ask);\n await sendWhatsApp(wa, ask);\n return;\n }\n\n // Explicit human request.\n if (parsed?.intent === \"handoff\") {\n lastPath = \"handoff\";\n await alertOwner(`Human requested`, `WhatsApp: +${wa}\\nName: ${name || \"unknown\"}\\nBusiness: ${business || \"unknown\"}\\nLast message: \"${body.slice(0, 300)}\"`);\n await ownerPing(`🙋 Human requested on HeyTrill bot: ${name || \"unknown\"} (+${wa}) - \"${body.slice(0, 120)}\"`);\n await addHistory(wa, \"assistant\", HANDOFF_MSG);\n await sendWhatsApp(wa, HANDOFF_MSG);\n return;\n }\n\n // Greeting on a fresh conversation.\n if (parsed?.intent === \"greeting\" && sess.step === \"new\" && history.length === 0) {\n const reply = greetingMsg(name);\n lastPath = \"greeting\";\n await setSession(wa, \"normal\", name, business, interest);\n await addHistory(wa, \"assistant\", reply);\n await sendWhatsApp(wa, reply);\n return;\n }\n\n // Everything else: AI reply, with long memory: full recent history + remembered facts.\n const vc = await getVisCtx(wa);\n await maybeSummarize(wa);\n const memSummary = await getMemory(wa);\n const facts = [\n name ? \"name: \" + name : \"\",\n business ? \"business: \" + business : \"\",\n interest ? \"interested in: \" + interest : \"\",\n vc.category ? \"their category: \" + vc.category : \"\",\n vc.city ? \"their city: \" + vc.city : \"\",\n \"conversation so far: \" + history.length + \" recent messages verbatim\" + (memSummary ? \" + full earlier chat below\" : \"\"),\n ].filter(Boolean).join(\"; \") + (memSummary ? \"\\nEARLIER IN THIS CHAT (running summary of everything before the recent messages): \" + memSummary : \"\");\n let reply = await aiReply(body, history, facts);\n for (let i = 0; i < 3 && !reply && lastAiStatus.startsWith(\"http 429\"); i++) {\n await new Promise((r) => setTimeout(r, 1500 * (i + 1)));\n reply = await aiReply(body, history, facts);\n }\n if (!reply) reply = await aiReply(body, history, facts); // one final try for non-429\n lastPath = reply ? \"ai\" : \"fallback\";\n if (!reply) {\n reply = greetingMsg(name); // AI unavailable: graceful, human-sounding fallback\n }\n if (reply.trim() === \"HANDOFF\" || reply.startsWith(\"HANDOFF\")) {\n lastPath = \"handoff_ai\";\n await alertOwner(`Question needs a human`, `WhatsApp: +${wa}\\nName: ${name || \"unknown\"}\\nBusiness: ${business || \"unknown\"}\\nQuestion: \"${body.slice(0, 300)}\"`);\n await ownerPing(`🙋 Bot needs you on HeyTrill chat: +${wa} asked \"${body.slice(0, 120)}\"`);\n reply = HANDOFF_MSG;\n }\n if (sess.step === \"confirm_lead\") {\n reply = reply + \"\\n\\n\" + confirmNudge;\n }\n if (sess.step === \"new\") await setSession(wa, \"normal\", name, business, interest);\n await addHistory(wa, \"assistant\", reply);\n await sendWhatsApp(wa, reply);\n}\n\n// ---------------- HTTP entry ----------------\nexport default async function (req: Request): Promise {\n const url = new URL(req.url);\n\n // Meta webhook verification\n if (req.method === \"GET\") {\n const mode = url.searchParams.get(\"hub.mode\");\n const token = url.searchParams.get(\"hub.verify_token\");\n const challenge = url.searchParams.get(\"hub.challenge\");\n if (mode === \"subscribe\" && token === VERIFY_TOKEN && challenge) {\n return new Response(challenge, { status: 200 });\n }\n // debug/diagnostics\n if (url.searchParams.get(\"debug\") === \"heytrill2026\") {\n await ensureTables();\n const sessions = await sqlite.execute(`SELECT * FROM ht_sessions ORDER BY updated_at DESC LIMIT 50`);\n const leads = await sqlite.execute(`SELECT * FROM ht_leads ORDER BY ts DESC LIMIT 50`);\n const outbox = await sqlite.execute(`SELECT * FROM ht_outbox ORDER BY ts DESC LIMIT 100`);\n return Response.json({ sessions: sessions.rows, leads: leads.rows, outbox: outbox.rows, meta_configured: !!(META_TOKEN && PHONE_NUMBER_ID) });\n }\n return new Response(\"heytrill assistant ok\");\n }\n\n if (req.method !== \"POST\") return new Response(\"ok\");\n\n // Test harness: {\"test\":true,\"from\":\"91...\",\"body\":\"...\"} -> runs the engine, replies recorded in outbox, returns JSON\n let payload: any;\n try {\n payload = await req.json();\n } catch (_e) {\n return new Response(\"bad json\", { status: 400 });\n }\n\n // IG send relay for the heytrill-receptionist val (it owns IG conversations since 2026-09-11;\n // this val holds the working Instagram-login token after the Facebook-login app lost IG capability).\n if (payload && payload.igrelay === \"heytrill2026\" && payload.to && payload.text) {\n await sendInstagram(String(payload.to), String(payload.text));\n return new Response(\"ok\", { status: 200 });\n }\n\n // Comment relay for the heytrill-receptionist val: reply to an IG comment, or list recent comments.\n if (payload && payload.igcomment === \"heytrill2026\" && payload.comment_id && payload.text) {\n const r = await fetch(`https://graph.instagram.com/v21.0/${String(payload.comment_id)}/replies`, {\n method: \"POST\",\n headers: { \"Authorization\": `Bearer ${IG_ACCESS_TOKEN}`, \"Content-Type\": \"application/json\" },\n body: JSON.stringify({ message: String(payload.text).slice(0, 1000) }),\n });\n const t = await r.text();\n return Response.json({ status: r.status, result: t.slice(0, 400) });\n }\n if (payload && payload.igcomments === \"heytrill2026\") {\n const out = { media: [] as any[], error: \"\" };\n try {\n const mr = await fetch(`https://graph.instagram.com/v21.0/me/media?fields=id,caption,timestamp&limit=8`, { headers: { \"Authorization\": `Bearer ${IG_ACCESS_TOKEN}` } });\n const mj = await mr.json();\n for (const m of (mj?.data || [])) {\n const cr = await fetch(`https://graph.instagram.com/v21.0/${m.id}/comments?fields=id,text,username,timestamp&limit=20`, { headers: { \"Authorization\": `Bearer ${IG_ACCESS_TOKEN}` } });\n const cj = await cr.json();\n out.media.push({ id: m.id, caption: String(m.caption || \"\").slice(0, 80), timestamp: m.timestamp, comments: cj?.data || [], comments_error: cj?.error || null });\n }\n } catch (e) { out.error = String(e).slice(0, 200); }\n return Response.json(out);\n }\n\n if (payload && payload.test === true) {\n const wa = String(payload.from || \"919999999999\");\n const body = String(payload.body || \"\");\n await ensureTables();\n const before = await sqlite.execute({ sql: `SELECT COUNT(*) FROM ht_outbox`, args: [] });\n const n0 = Number(before.rows?.[0]?.[0] || 0);\n await handleMessage(wa, body);\n const after = await sqlite.execute({ sql: `SELECT text FROM ht_outbox ORDER BY id`, args: [] });\n const texts = (after.rows || []).slice(n0).map((r) => String(r[0]));\n return Response.json({ replies: texts, path: lastPath, ai_status: lastAiStatus });\n }\n\n // Instagram Messaging webhook (object=\"instagram\")\n // FORWARD-ONLY since 2026-09-11: the heytrill-receptionist val owns all IG handling.\n if (payload?.object === \"instagram\") {\n try {\n await fetch(\"https://deepthisudhakar023--bd31d162acfb11f18f6c1607ee4eb77e.web.val.run\", {\n method: \"POST\",\n headers: { \"Content-Type\": \"application/json\" },\n body: JSON.stringify(payload),\n });\n } catch (_e) { /* best effort */ }\n return new Response(\"ok\", { status: 200 });\n }\n if (false) {\n // Ack fast, process bounded: Meta retries if we're slow, and retries must never duplicate replies.\n const igProcess = (async () => {\n try {\n await ensureTables();\n for (const entry of payload?.entry ?? []) {\n for (const ev of entry?.messaging ?? []) {\n const sender = String(ev?.sender?.id || \"\");\n if (!sender || sender === IG_USER_ID) continue;\n const msg = ev?.message;\n if (!msg) continue; // delivery receipts, read receipts, reactions: not messages, ignore\n if (msg.is_echo) continue; // our own replies echoed back\n const mid = String(msg.mid || \"\");\n if (mid) {\n if (await alreadyProcessed(\"ig:\" + mid)) continue; // retry-safe\n await markProcessed(\"ig:\" + mid);\n }\n if (msg.text) {\n await handleMessage(\"ig:\" + sender, String(msg.text));\n } else if (msg.attachments || msg.sticker_id || msg.reply_to) {\n // genuinely unsupported content: throttle to one fallback per sender per 15 min\n try {\n const recent = await sqlite.execute({\n sql: `SELECT id FROM ht_outbox WHERE wa_id = ? AND text LIKE 'igfallback:%' AND ts > ? LIMIT 1`,\n args: [\"ig:\" + sender, Date.now() - 15 * 60 * 1000],\n });\n if (!recent.rows || recent.rows.length === 0) {\n await sqlite.execute({\n sql: `INSERT INTO ht_outbox (wa_id, text, ts) VALUES (?, ?, ?)`,\n args: [\"ig:\" + sender, \"igfallback:marker\", Date.now()],\n });\n await sendWhatsApp(\"ig:\" + sender, `sorry, i can only read text messages for now - could you type that out?`);\n }\n } catch (e) { /* never block the ack */ }\n }\n // anything else (likes, story reacts without attachment): ignore silently\n }\n }\n } catch (err) { /* always 200 so Meta doesn't retry-storm */ }\n })();\n await Promise.race([igProcess, new Promise((r) => setTimeout(r, 12000))]);\n return new Response(\"ok\", { status: 200 });\n }\n\n // Meta Cloud API webhook\n try {\n for (const entry of payload?.entry ?? []) {\n for (const change of entry?.changes ?? []) {\n const value = change?.value;\n const messages = value?.messages;\n if (!Array.isArray(messages)) continue; // statuses etc: ignore\n for (const msg of messages) {\n const wa = String(msg?.from || \"\");\n const id = String(msg?.id || \"\");\n if (!wa || !id) continue;\n if (await alreadyProcessed(id)) continue;\n await markProcessed(id);\n if (msg?.type === \"text\" && msg?.text?.body) {\n await handleMessage(wa, String(msg.text.body));\n } else {\n const fallback = `Sorry, I can only read text messages for now - could you type that out?`;\n await sendWhatsApp(wa, fallback);\n }\n }\n }\n }\n } catch (err) {\n return new Response(\"error\", { status: 200 }); // always 200 so Meta doesn't retry-storm\n }\n return new Response(\"ok\", { status: 200 });\n}\n","deleted",false,"label",[14],"3630226e-2970-4296-8bd2-a5a5c7d0739a",["D",1788595835206],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","imageUrl","userId","a7b0a2c2-1be4-4203-9fcd-83311077f65b","pinnedFileId","7cd6c472-a901-11f1-8513-1607ee4eb77e","pinPreview","pinMigrated","screenshotVersion","likeCount",0,"orgId","01a0709c-b2b2-772d-ba3f-c6e0c645cf6d","tursoName","3630226e297042968bd2a5a5c7d0739a","tursoHostname","3630226e297042968bd2a5a5c7d0739a-val-town.aws-us-east-2.turso.io","tursoMeasuredAt",["D",1789476648181],"pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_9":10,"_103":98},"org",{"_9":10,"_97":98,"_99":98,"_54":55,"_100":101,"_102":42},"branch",{"_35":30,"_11":88,"_22":28,"_89":45,"_90":-5,"_91":-5,"_92":-5,"_93":-5,"_94":-5,"_95":12,"_96":10},"isOwned","main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","displayName","","avatar","tier","free","canRestrictVals","profileImageUrl","ctx",{"_81":-5,"_137":138,"_139":140,"_141":142,"_143":42,"_144":42,"_145":42,"_146":32,"_147":-5,"_148":-7,"_149":-7,"_150":62,"_151":42,"_152":42,"_153":-5,"_154":42,"_155":42,"_156":42,"_157":-5},"ENV",{"_108":109,"_110":111,"_112":88,"_113":114,"_115":116,"_117":118,"_119":120,"_121":122,"_123":124,"_125":126,"_127":128,"_129":130,"_131":132,"_133":134,"_135":136},"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"]