HeyTrill Inbox

[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_153":154,"_155":156},"routes/_app.x.$handle.$name",{"_11":12,"_13":14,"_15":16,"_18":19,"_17":-7,"_114":-5,"_20":115,"_22":116,"_117":118,"_119":120,"_26":121,"_24":122,"_123":-5,"_124":-5,"_125":56,"_126":127,"_128":53,"_129":-5,"_130":-5,"_131":132},"routes/_app.x.$handle.$name.branch.$branch.code.$",{"_11":12,"_13":14,"_15":16,"_17":-7,"_18":19,"_20":21,"_22":23,"_24":25,"_26":27,"_28":-5,"_29":-5,"_30":-5,"_31":-5,"_32":-5},"handle","deepthisudhakar023","name","heytrill-receptionist","branchName","main","version","path","main.ts","project",{"_33":60,"_13":14,"_45":61,"_62":-5,"_63":56,"_64":65,"_66":65,"_67":-5,"_68":-5,"_69":70,"_71":38,"_72":53,"_73":-5,"_74":-5,"_75":76,"_77":78,"_79":-5,"_80":-5,"_81":-5,"_82":-5,"_83":84,"_85":84,"_86":87,"_88":87,"_89":87,"_90":84,"_91":84,"_92":93,"_94":95,"_96":97,"_98":56},"tree",[51],"file",{"_33":34,"_35":36,"_37":38,"_13":19,"_39":40,"_41":42,"_17":43,"_44":-5,"_45":46,"_47":48,"_49":-5,"_18":50},"contents",[],"upstream","pull","ahead","behind","envVars","id","951e340d-8a36-4fd4-bfff-840764979c8b","branchId","9dfff0ac-81ac-4560-821b-ad5d97e12add","fileId","bd31d162-acfb-11f1-8f6c-1607ee4eb77e","content","// HeyTrill AI Receptionist - WhatsApp + Instagram bot on Meta Cloud API. v54: IG human takeover (\"it's deepthi\" mutes a thread, \"bot on\" releases). v55: log ig webhook errors. v56: IG sends via salonbot-val relay (Instagram-login token). v57: curly apostrophes + near-miss logs. v58: takeover phrase matches ANYWHERE in the echo (her rule). v59: voice-note transcription via Groq Whisper on WA+IG. v60: Gemini vision for photos (activates when GEMINI_API_KEY env is set; graceful fallback without it). v61: IG story replies answered with story context (story link + Gemini description of story image when key present). v62: geminimodels debug endpoint (forces fresh isolate so GEMINI_API_KEY env is visible). v63: vision model list fixed (flash-lite first), maxOutputTokens 1024 (2.5-flash thinking eats small budgets), empty-response logging. v69: inbox reply dedupe guard (2-min same-text window) after the Ravi 9x duplicate burst. v67: Deepthi's web inbox (?inbox=KEY): WA+IG thread list, history, reply-as-business form, mute badges. v66: IG post-comment auto-replies (public, brand voice, FLAG: sensitive ones + WhatsApp alert to Deepthi, mute-consistent) via salonbot comment relay. v65: coexistence guard - WA Business-app echoes from our own number are ignored (prep for linking the app to the bot number). v64: her key is a new-project key - 2.5/2.0/1.5 models 404 for new users; moved to gemini-3.x flash models with flash-latest fallback.\n// Answers questions about HeyTrill's two services, 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 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 hi = name ? `Hey ${name}!` : pick([\"Hey!\", \"Hi!\", \"Hey there!\"]);\n return pick([\n `${hi} This is HeyTrill. We put an AI receptionist on your WhatsApp + Instagram that answers and books customers 24/7, we get your business named by ChatGPT, and we build websites. Easiest start: a free AI visibility check on your business. What business are we looking at?`,\n `${hi} You've got HeyTrill - we answer your customers on WhatsApp + Instagram 24/7, get you named by ChatGPT, and build websites. First one's free: a quick AI visibility check for your business. What's it called?`,\n ]);\n};\n\nconst HANDOFF_MSG = pick([\n `That one's for Deepthi herself - she'll jump in here shortly. Anything else I can sort meanwhile?`,\n `Good one - Deepthi (our founder) will take that herself and reply here shortly. Anything else meanwhile?`,\n]);\n\nconst confirmLeadAsk = (name: string, biz: string, interest: string) =>\n `Just to confirm, ${name}: you're interested in *${interest}* for *${biz}*. I'll have Deepthi reach out 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 problem, 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_SYSTEM = `You are the front-desk person at HeyTrill, texting prospective clients on WhatsApp. You come across as a real human operator: sharp, warm, a bit witty, never corporate. Like a competent friend who runs front desk.\n\nHOW YOU TEXT (this matters most - follow it exactly):\n- 1-3 short sentences, max ~40 words. Never a wall of text. A tiny list only when it genuinely helps (like a price breakdown).\n- Answer the question FIRST. Then at most one natural follow-up - and only if it helps them. Don't end every message with a question.\n- Contractions always: you're, we'll, it's, don't, that's.\n- Simple words: \"fix\", \"set up\", \"use\" - never \"resolve\", \"establish\", \"utilize\".\n- No corporate phrasing, no brochure talk. Never start with \"Certainly\", \"I'd be happy to\", \"Absolutely\", \"Great question\", \"Happy to help\", \"Great choice\".\n- Dry humor is welcome when natural, never forced.\n- If you don't know, say so plainly and offer the human path. Admitting beats bluffing.\n- Emojis: rare. Most messages have none. At most one.\n- Never re-introduce HeyTrill - the first greeting covered it. Only if they literally ask \"what do you do\".\n- Reply in the same language they write in: English, Hindi, Kannada, Hinglish, any mix. Default English.\n- Use the chat history. If they refer back (\"that one\", \"the audit\", \"and the bot?\"), just answer with that context.\n- If you know their name, use it once in a while, not every message.\n\nWHAT HEYTRILL IS (answer ONLY from this):\n- HeyTrill is an AI services company founded by Deepthi S, working with businesses everywhere.\n- The deal: we build it, we run it, we maintain it. Owners never touch anything technical - they talk to us on WhatsApp like messaging someone on their own team.\n- Two systems, one customer journey: AI Visibility gets the business discovered, the AI Assistant turns that discovery into a booked customer.\n- Public contact: WhatsApp +91 63620 39431 and deepthi@heytrill.com - but this chat is the fastest path.\n\nSERVICE 1 - AI Assistant for WhatsApp + Instagram:\n- One bot brain across both apps, on the business's own WhatsApp Business number (or a second number if they prefer - their call). Answers every customer in seconds, 24/7: prices, services, timings, location, directions. Even at 2 AM.\n- Takes bookings: customers pick a slot and get a confirmation on the spot, booked against the hours and rules the owner gives us. Every booking lands in the owner's own WhatsApp - they always have the final word.\n- Instagram included: instant DM replies, plus comment-to-DM - someone comments on a post, the bot DMs them automatically.\n- It never invents an answer. The moment it isn't sure, it says so, alerts the owner's team, and a human takes over the chat. No invented prices, timings or policies.\n- The owner sees every conversation, always. Updates take one WhatsApp message to us - new price, timing or service goes live. No code, no dashboards, no logins.\n- Trained on the business's exact services, rates, timings and tone of voice. Answers in English, Kannada or Hindi.\n- The Sunday Brief is included: every Sunday on the owner's WhatsApp - bookings won and missed, what customers asked for most, new Google reviews, their quiet hours. One message, zero dashboards.\n- Pricing: FOUNDING 5 rate - Rs.9,999 one-time setup + Rs.5,999/month (covers 1 WhatsApp number, 1 Instagram account, 1 location; Meta's per-message costs pass through at cost). Locked for the first 5 client businesses for as long as they stay - in exchange for honest feedback and an anonymised case study. After the founding 5 are gone, the standard rate is Rs.14,999 setup + Rs.7,999/month.\n- Timeline: live in about a week. ~20 minutes of the owner's time (one chat about services, prices, timings, what customers ask most), we build in 2-3 days, they message it and try to break it - nothing goes live until they love every answer - then official Meta setup and verification, handled by us start to finish.\n\nSERVICE 2 - AI Search Visibility:\n- Getting the business named when customers ask ChatGPT, Gemini or Perplexity where to go. Google helps customers find pages; AI helps them decide what to choose - we make the business the answer.\n- The process, no algorithm tricks: 1) Understand - analyse what AI systems currently know about the business and what they don't. 2) Diagnose - identify missing, inconsistent or weak information hurting discoverability. 3) Strengthen - improve the website, listings and profiles so services, location, expertise and differentiators are easier for AI to understand. 4) Measure - repeatedly test the real questions customers ask across AI platforms, so progress is tracked, not guessed.\n- The audit: Rs.14,999 (FOUNDING 5 rate, locked for the first 5 clients). Week 1: the AI Visibility Report - the exact questions customers ask ChatGPT, Gemini and other AI platforms, and whether the business is named, question by question, with the raw AI answers as screenshots. Plus a 0-100 AI Visibility Score (business information, service discoverability, local relevance, third-party mentions, AI recommendations), tracked month over month. Fixes roll out everywhere AI assistants read, with monthly before/after proof they can verify themselves, and scheduled re-testing so they stay named as AI answers change.\n- After the audit: ongoing monitoring and optimisation runs at Rs.9,999/month (FOUNDING 5 rate; Rs.14,999/month standard after the founding 5) - most founding clients start with the audit first.\n- HeyTrill Growth (AI Assistant + AI Visibility + Sunday Brief, everything managed, one team, one WhatsApp thread, one flat monthly fee): FOUNDING 5 rate Rs.19,999 setup + Rs.14,999/month. After the founding 5: Rs.29,999 setup + Rs.24,999/month.\n- We also build websites - website pricing is NOT published yet. If asked about website pricing, say pricing for websites is coming soon and is discussed on a quick call with Deepthi - never quote any website number.\n\nPRICE LIST (quote ONLY these numbers, verbatim - never any other figure):\n- FOUNDING 5 (first 5 clients, rate locked for as long as they stay): AI Assistant Rs.9,999 setup + Rs.5,999/month. AI Visibility Rs.14,999 audit + Rs.9,999/month ongoing. HeyTrill Growth (both + Sunday Brief) Rs.19,999 setup + Rs.14,999/month.\n- AFTER FOUNDING 5 (future standard rates): Assistant Rs.14,999 + Rs.7,999/month. Visibility Rs.19,999 + Rs.14,999/month. Growth Rs.29,999 + Rs.24,999/month. Mention these only as \"the rate goes up after the founding 5 are gone\" unless they ask for the future numbers.\n- Websites: unpriced - pricing coming soon, discussed on a call with Deepthi.\n\nWHY IT'S WORTH IT (only if they hesitate on price):\n- 2 missed enquiries a day x 30 days = 60 missed customers. If just 10 come back as appointments, the month has paid for itself - and most businesses miss far more than 2 a day. Frame it as illustrative, never a promise - their free audit shows their real numbers.\n\nWHAT YOU CAN DO LIVE IN THIS CHAT:\n- Run a quick live visibility check: 3 real customer questions asked to AI tools, named or not named, delivered in chat. It fires automatically when someone signs up for the free audit with their business name. If they ask about it, describe it that way - the full scorecard (0-100, 20+ questions, screenshots, fixes) follows within a day, verified by Deepthi.\n- Do quick live web lookups for competitor and market questions. When you used one, say \"a quick web search\" or \"I checked\" - natural, no tool talk.\n- Honesty about engines: NEVER claim you asked ChatGPT or any specific product. Say \"AI tools\" or \"AI assistants\".\n- NEVER invent business names, competitor names, ratings, or review counts. If you don't have real search results in front of you, say you can't check right now.\n\nNEXT STEP FOR PROSPECTS:\n- The free AI visibility check. They send their business name (and WhatsApp number); we ask ChatGPT the real questions their customers ask and WhatsApp them a simple report: their score, who gets named, who doesn't, and what we'd improve first. Free, no commitment, we reply within a day. You collect name, business name, and which service they're eyeing; Deepthi reaches out on WhatsApp.\n- Payment, contracts, invoices: Deepthi handles those directly. You never discuss them.\n\nHARD RULES:\n1. Never invent a price, discount, feature, timeline, or policy. Not in the data above? Reply with exactly one word: HANDOFF\n2. Questions about the services, pricing, what's included, setup, timelines, and the free audit ARE answerable above - answer them, don't hand off.\n3. Small talk (\"how are you\", \"thanks\", \"ok\", \"nice\", \"bye\") is not a handoff: answer briefly like a person, then steer back to how we can help.\n4. If they ask who or what you are: say you're HeyTrill's AI assistant, plainly - it's fine - and that this is literally service 1 in action.\n5. Never discuss competitors' pricing or bad-mouth anyone. Describe what HeyTrill does and let it speak for itself.\n6. Never share anyone's personal number or internal details beyond the public contact info above. This chat is the contact path.\n7. No discounts beyond the founding offer, no custom quotes, no delivery dates beyond \"about a week\". Those are HANDOFF.\n8. If they ask for a human, a call, or Deepthi: reply exactly: HANDOFF\n9. A greeting or small talk (\"hey bro\", \"hello\", \"lol\", \"nice\", \"ok\") is NEVER a yes and never an answer to your last question. Only treat it as consent when they clearly say yes/sure/go ahead (or answer what you asked). If your last message ended in a question and they just banter, banter back in one short line and lightly re-ask once.\n10. Who founded HeyTrill: the ONLY fact you have is \"HeyTrill is founded by Deepthi S.\" Never invent a backstory, history, or biography - no \"she started it after...\", nothing. If they push for more than that one fact, offer to connect them with her (reply exactly: HANDOFF).\n11. If anyone asks for HeyTrill's Instagram / Insta / IG link, handle, or page: just give it - https://www.instagram.com/heytrill.team/ - one short line. That's public info, never a HANDOFF, never an alert.\n13. Everything circles back to business, mid-chat too. When the chat drifts off-topic (personal recommendations, trivia, banter), answer in one short line, then steer back toward HeyTrill - the WhatsApp + Instagram assistant, AI visibility, websites, or the free AI visibility check - in one short line. Light, human, never pushy, never a pitch wall. When the chat is already about business, skip the steering. One steer per lull, not on every message.\n12. \"HANDOFF\" is a secret internal signal. You ONLY ever emit it as the exact one-word reply per rule 1/8/10. NEVER write it inside a normal message, NEVER mention it, NEVER explain it, NEVER say the words \"hand off\", \"handoff\", \"cue\", or \"internal signal\" to describe it. If someone asks what \"HANDOFF\" means or whether it's a brand, act like nothing happened: apologize for the confusion in one short line and answer their previous real question instead.`;\n\nlet lastAiError = \"\";\n\n// Groq free tier dies under parallel bursts: cap concurrent Groq calls, jitter retries.\nconst GROQ_SEM = { n: 0, q: [] as Array<() => void> };\nasync function groqSlot(): Promise {\n if (GROQ_SEM.n < 4) { GROQ_SEM.n++; return; }\n await new Promise((r) => GROQ_SEM.q.push(r));\n GROQ_SEM.n++;\n}\nfunction groqRelease(): void {\n GROQ_SEM.n--;\n const next = GROQ_SEM.q.shift();\n if (next) next();\n}\nconst jitter = (base: number) => base + Math.floor(Math.random() * 1200);\n\nasync function aiReply(userText: string, history: { role: string; text: string }[]): Promise {\n const key = Deno.env.get(\"GROQ_API_KEY\");\n if (!key) return null;\n // Primary model twice, then a different model as rate-limit backup (separate Groq limits per model).\n const replyModels = [\"openai/gpt-oss-120b\", \"openai/gpt-oss-120b\", \"openai/gpt-oss-20b\", \"qwen/qwen3.8-27b\", \"openai/gpt-oss-20b\", \"allam-2-7b\"];\n for (let mi = 0; mi < replyModels.length; mi++) {\n const r = await aiReplyOnce(userText, history, key, replyModels[mi]);\n if (r) return r;\n await new Promise((res) => setTimeout(res, 900 + mi * 500 + Math.floor(Math.random() * 600)));\n }\n return null;\n}\n\nasync function aiReplyOnce(userText: string, history: { role: string; text: string }[], key: string, model: string): Promise {\n await groqSlot();\n try {\n const ctrl = new AbortController();\n const timer = setTimeout(() => ctrl.abort(), 9000);\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,\n ...(model.startsWith(\"openai/gpt-oss\") ? { reasoning_effort: \"low\" } : {}),\n temperature: 0.3,\n max_completion_tokens: 400,\n messages: [\n { role: \"system\", content: AI_SYSTEM },\n ...history.slice(-8).map((h) => ({ role: h.role === \"user\" ? \"user\" : \"assistant\", content: h.text.slice(0, 350) })),\n { role: \"user\", content: userText },\n ],\n }),\n signal: ctrl.signal,\n });\n clearTimeout(timer);\n if (!res.ok) { const m = model + \" http \" + res.status + \": \" + (await res.text()).slice(0, 180); lastAiError = m; logErr(\"aiReply \" + m); 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 && !/[A-Za-z]{3,}/.test(txt)) { logErr(`aiReply ${model} bad-output: ` + txt.slice(0, 80)); txt = \"\"; }\n if (!txt) { lastAiError = \"empty content: \" + JSON.stringify(j?.choices?.[0]?.message || j).slice(0, 180); logErr(\"aiReply \" + lastAiError); }\n return txt || null;\n } catch (_e) {\n lastAiError = \"throw: \" + String(_e).slice(0, 180);\n logErr(\"aiReply \" + lastAiError);\n return null;\n } finally {\n groqRelease();\n }\n}\n\nconst VALID_INTENTS = [\"book\", \"query\", \"greeting\", \"smalltalk\", \"handoff\", \"other\"];\nconst VALID_INTERESTS = [\"receptionist\", \"visibility\", \"both\"];\n\nasync function parseMessage(userText: string, history: { role: string; text: string }[]): Promise<{ intent: string; name: string | null; business: string | null; interest: string | null; searchq: 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 receptionist. 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|research|greeting|smalltalk|handoff|other\",\"name\":\"first name|null\",\"business\":\"business name|null\",\"interest\":\"receptionist|visibility|both|null\",\"searchq\":\"search query|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\"). query = asks a question about HeyTrill's services/pricing/process. research = wants a live lookup about THEIR business or market: competitors, other businesses LIKE THEIRS, prices in their area, reviews/news about a business. Misspellings still count (\"comptetior\", \"competetor\" = competitor). Generic questions with no business angle (best cafe to visit, trivia, recommendations for personal use) are NOT research - they are query or other. 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- name: the prospect's first name, ONLY if they introduce themselves in this message. Otherwise null.\n- business: their business name, ONLY if stated in this message. Otherwise null.\n- interest: receptionist = the WhatsApp + Instagram AI receptionist/bot. visibility = AI search visibility/GEO/ChatGPT ranking - the free audit / free visibility check also maps here. both = both services. null if unclear.\n- searchq: for research intent ONLY - the clean search-engine query that finds what they want. Convert first-person chat into plain keywords: \"I run milano ice cream, who are my competitors\" -> \"Milano Ice Cream competitors\". \"any other salons near me in Indiranagar\" -> \"salons in Indiranagar Bangalore\". Include city/area when stated or known from chat. If they have NOT said what their business or industry is and it is not known from chat, searchq MUST be null (a bare \"my competitors\" with nothing to search is useless). null for every other intent.\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 await groqSlot();\n try {\n for (const model of [\"openai/gpt-oss-20b\", \"openai/gpt-oss-120b\"]) {\n const ctrl = new AbortController();\n const timer = setTimeout(() => ctrl.abort(), 10000);\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,\n reasoning_effort: \"low\",\n temperature: 0,\n max_completion_tokens: 120,\n messages: [\n { role: \"system\", content: system },\n { role: \"user\", content: history.length ? \"Recent chat:\\n\" + history.slice(-6).map((h) => (h.role === \"user\" ? \"Prospect\" : \"Bot\") + \": \" + h.text.slice(0, 250)).join(\"\\n\") + \"\\n\\nProspect's new message: \" + userText : userText },\n ],\n }),\n signal: ctrl.signal,\n });\n clearTimeout(timer);\n if (!res.ok) { logErr(`parse ${model} http ${res.status}`); continue; }\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) continue;\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().toLowerCase() !== \"null\" ? p.name.trim() : null,\n business: typeof p.business === \"string\" && p.business.trim().length >= 2 && p.business.trim().length <= 60 && p.business.trim().toLowerCase() !== \"null\" ? p.business.trim() : null,\n interest: VALID_INTERESTS.includes(p.interest) ? p.interest : null,\n searchq: typeof p.searchq === \"string\" && p.searchq.trim().length >= 4 && p.searchq.trim().length <= 120 ? p.searchq.trim() : null,\n };\n }\n return null;\n } catch (_e) {\n return null;\n } finally {\n groqRelease();\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_teaser (wa_id TEXT PRIMARY KEY, ts INTEGER)`);\n await sqlite.execute(`CREATE TABLE IF NOT EXISTS ht_errlog (id INTEGER PRIMARY KEY AUTOINCREMENT, msg TEXT, ts INTEGER)`);\n await sqlite.execute(`CREATE TABLE IF NOT EXISTS ht_muted (wa_id TEXT PRIMARY KEY, 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 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 20)`, 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 12`, 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}\nasync function isMuted(wa: string): Promise {\n await ensureTables();\n const r = await sqlite.execute({ sql: `SELECT 1 FROM ht_muted WHERE wa_id = ?`, args: [wa] });\n return !!(r.rows && r.rows.length);\n}\nasync function setMuted(wa: string, on: boolean) {\n await ensureTables();\n if (on) await sqlite.execute({ sql: `INSERT OR REPLACE INTO ht_muted (wa_id, ts) VALUES (?, ?)`, args: [wa, Date.now()] });\n else await sqlite.execute({ sql: `DELETE FROM ht_muted WHERE wa_id = ?`, args: [wa] });\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\n// ---------------- Meta send ----------------\nconst captureMap = new Map();\nasync function sendWhatsApp(wa: string, text: string) {\n await ensureTables();\n const cap = captureMap.get(wa); if (cap) { cap.push(text); return; }\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 let status = 0;\n for (let attempt = 0; attempt < 2; attempt++) {\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: wa, type: \"text\", text: { body: text } }),\n });\n status = res.status;\n if (res.ok) return;\n } catch (_e) { status = -1; }\n if (attempt === 0) await new Promise((res) => setTimeout(res, 1200));\n }\n await sqlite.execute({ sql: `INSERT INTO ht_outbox (wa_id, text, ts) VALUES (?, ?, ?)`, args: [wa, \"SEND FAILED x2: \" + status + \" :: \" + text.slice(0, 200), Date.now()] });\n}\n\nasync function sendReply(dest: string, text: string) {\n if (dest.startsWith(\"ig:\")) return sendIG(dest.slice(3), text);\n return sendWhatsApp(dest, text);\n}\n\nasync function sendIG(igsid: string, text: string) {\n await ensureTables();\n const cap = captureMap.get(\"ig:\" + igsid); if (cap) { cap.push(text); return; }\n // v56: route IG sends through the salonbot val's relay - it holds the working Instagram-login\n // token (our Facebook-login app lost instagram_manage_messages capability on 2026-09-11).\n let relayed = false;\n for (let attempt = 0; attempt < 2 && !relayed; attempt++) {\n try {\n const res = await fetch(\"https://deepthisudhakar023--cc5c8056acfb11f1a2541607ee4eb77e.web.val.run\", {\n method: \"POST\",\n headers: { \"Content-Type\": \"application/json\" },\n body: JSON.stringify({ igrelay: \"heytrill2026\", to: igsid, text }),\n });\n relayed = res.ok;\n } catch (_e) { relayed = false; }\n if (!relayed && attempt === 0) await new Promise((res) => setTimeout(res, 1200));\n }\n if (relayed) return;\n await sqlite.execute({ sql: `INSERT INTO ht_outbox (wa_id, text, ts) VALUES (?, ?, ?)`, args: [\"ig:\" + igsid, \"IG RELAY FAILED x2 :: \" + text.slice(0, 180), Date.now()] });\n return;\n}\nasync function sendIG_dead(igsid: string, text: string) {\n await ensureTables();\n const cap = captureMap.get(\"ig:\" + igsid); if (cap) { cap.push(text); return; }\n const IG_USER_ID = Deno.env.get(\"IG_USER_ID\");\n if (!META_TOKEN || !IG_USER_ID) {\n await sqlite.execute({ sql: `INSERT INTO ht_outbox (wa_id, text, ts) VALUES (?, ?, ?)`, args: [\"ig:\" + igsid, \"IG NOT CONFIGURED: \" + text.slice(0, 180), Date.now()] });\n return;\n }\n let status = 0;\n for (let attempt = 0; attempt < 2; attempt++) {\n try {\n const res = await fetch(`https://graph.facebook.com/v24.0/${IG_USER_ID}/messages`, {\n method: \"POST\",\n headers: { \"Authorization\": `Bearer ${META_TOKEN}`, \"Content-Type\": \"application/json\" },\n body: JSON.stringify({ recipient: { id: igsid }, message: { text } }),\n });\n status = res.status;\n if (res.ok) return;\n } catch (_e) { status = -1; }\n if (attempt === 0) await new Promise((res) => setTimeout(res, 1200));\n }\n await sqlite.execute({ sql: `INSERT INTO ht_outbox (wa_id, text, ts) VALUES (?, ?, ?)`, args: [\"ig:\" + igsid, \"IG SEND FAILED x2: \" + status + \" :: \" + text.slice(0, 180), Date.now()] });\n}\n\nasync function alertOwner(subject: string, text: string) {\n try {\n await email({ subject: `${OWNER_NOTE}: ${subject}`, text });\n } catch (_e) { /* best effort */ }\n}\n\n// ---------------- live teaser + web research ----------------\nconst ERRLOG: string[] = [];\nfunction logErr(m: string) {\n ERRLOG.push(new Date().toISOString() + \" \" + m);\n if (ERRLOG.length > 60) ERRLOG.shift();\n sqlite.execute({ sql: `INSERT INTO ht_errlog (msg, ts) VALUES (?, ?)`, args: [m.slice(0, 400), Date.now()] }).catch(() => {});\n}\n\n// ---------------- media: voice-note transcription (Groq Whisper, free tier) ----------------\nasync function fetchBytes(u: string, auth?: string): Promise<{ bytes: Uint8Array; mime: string } | null> {\n try {\n const r = await fetch(u, auth ? { headers: { Authorization: auth } } : {});\n if (!r.ok) return null;\n return { bytes: new Uint8Array(await r.arrayBuffer()), mime: r.headers.get(\"content-type\") || \"application/octet-stream\" };\n } catch (_e) { return null; }\n}\nasync function waMediaUrl(id: string): Promise {\n try {\n const r = await fetch(`https://graph.facebook.com/v24.0/${id}`, { headers: { Authorization: `Bearer ${META_TOKEN}` } });\n if (!r.ok) return null;\n const j = await r.json();\n return j?.url ? String(j.url) : null;\n } catch (_e) { return null; }\n}\nasync function groqTranscribe(bytes: Uint8Array, mime: string, filename: string): Promise {\n const key = Deno.env.get(\"GROQ_API_KEY\");\n if (!key) return null;\n try {\n const fd = new FormData();\n fd.append(\"file\", new Blob([bytes], { type: mime.split(\";\")[0] }), filename);\n fd.append(\"model\", \"whisper-large-v3-turbo\");\n const r = await fetch(\"https://api.groq.com/openai/v1/audio/transcriptions\", {\n method: \"POST\",\n headers: { \"Authorization\": `Bearer ${key}` },\n body: fd,\n });\n if (!r.ok) { logErr(\"whisper http \" + r.status + \": \" + (await r.text()).slice(0, 150)); return null; }\n const j = await r.json();\n const t = String(j?.text || \"\").trim();\n return t || null;\n } catch (e) { logErr(\"whisper throw: \" + String(e).slice(0, 120)); return null; }\n}\nasync function transcribeFromUrl(u: string, auth?: string): Promise {\n const fb = await fetchBytes(u, auth);\n if (!fb || fb.bytes.length === 0) return null;\n const ext = fb.mime.includes(\"ogg\") ? \"voice.ogg\" : fb.mime.includes(\"mp4\") || fb.mime.includes(\"m4a\") ? \"voice.m4a\" : fb.mime.includes(\"mpeg\") || fb.mime.includes(\"mp3\") ? \"voice.mp3\" : fb.mime.includes(\"webm\") ? \"voice.webm\" : \"voice.ogg\";\n return groqTranscribe(fb.bytes, fb.mime, ext);\n}\n// Gemini vision (free-tier API key in GEMINI_API_KEY env; absent -> photo ack fallback)\nfunction b64encode(bytes: Uint8Array): string {\n let s = \"\";\n const CHUNK = 8192;\n for (let i = 0; i < bytes.length; i += CHUNK) s += String.fromCharCode(...bytes.subarray(i, i + CHUNK));\n return btoa(s);\n}\nasync function geminiDescribe(bytes: Uint8Array, mime: string): Promise {\n const key = Deno.env.get(\"GEMINI_API_KEY\");\n if (!key) return null;\n const b64 = b64encode(bytes);\n const mt = (mime.split(\";\")[0] || \"image/jpeg\");\n for (const model of [\"gemini-3.5-flash\", \"gemini-3.1-flash-lite\", \"gemini-3.6-flash\", \"gemini-flash-latest\"]) {\n try {\n const r = await fetch(`https://generativelanguage.googleapis.com/v1beta/models/${model}:generateContent?key=${key}`, {\n method: \"POST\",\n headers: { \"Content-Type\": \"application/json\" },\n body: JSON.stringify({\n contents: [{ parts: [\n { text: \"Describe this image in 2-4 plain sentences for a business chatbot: what it shows, any readable text, prices, names, dates. Be literal, no guessing.\" },\n { inline_data: { mime_type: mt, data: b64 } },\n ] }],\n generationConfig: { maxOutputTokens: 1024 },\n }),\n });\n if (!r.ok) { logErr(`gemini ${model} http ` + r.status + \": \" + (await r.text()).slice(0, 150)); continue; }\n const j = await r.json();\n const t = String(j?.candidates?.[0]?.content?.parts?.map((p: any) => p?.text || \"\").join(\" \") || \"\").trim();\n if (t) return t.slice(0, 600);\n logErr(`gemini ${model} empty: ` + JSON.stringify(j?.candidates?.[0]?.finishReason || j).slice(0, 180));\n } catch (e) { logErr(`gemini ${model} throw: ` + String(e).slice(0, 120)); }\n }\n return null;\n}\n\nconst VOICE_FAIL_MSG = `Sorry, I couldn't make out that voice note - could you type it out?`;\nconst PHOTO_MSG = `Got your photo! I can't view images properly yet - can you tell me what it shows?`;\nconst INBOX_KEY = \"tb-66c366e574bb\"; // Deepthi's web inbox access key (hand-delivered via WA)\n\n// Public IG comment answers: same front-desk voice, tightened for public view, FLAG: prefix = loop in Deepthi.\nasync function answerComment(username: string, text: string): Promise {\n const system = AI_SYSTEM + `\n\nNOW: You are answering a PUBLIC Instagram comment on a HeyTrill post, not a DM. Extra rules for this:\n- MAX 1-2 short sentences, under ~180 characters. Public replies stay tight.\n- Everything you write is PUBLIC - never include private details, customer info, or anything you wouldn't want on a billboard.\n- Answer only from the HeyTrill facts you know. If the comment asks about something outside them (a service we don't list, pricing negotiation, a complaint, a refund, a personal situation), do NOT invent an offer or price - reply warmly and generically and invite them to DM, and start your answer with \"FLAG:\" so Deepthi gets looped in. Also FLAG anything rude or sensitive.\n- When more detail is needed, invite them to DM - don't start a back-and-forth thread in public comments.`;\n return groqAsk(system, `@${username || \"user\"} commented on our Instagram post: \"${text.slice(0, 400)}\"`, 220);\n}\n\nasync function groqAsk(system: string, user: string, maxTokens = 300, models: string[] = [\"openai/gpt-oss-120b\", \"openai/gpt-oss-120b\", \"openai/gpt-oss-20b\", \"qwen/qwen3.8-27b\", \"allam-2-7b\"]): Promise {\n const key = Deno.env.get(\"GROQ_API_KEY\");\n if (!key) return null;\n for (const model of models) {\n await groqSlot();\n try {\n const ctrl = new AbortController();\n const timer = setTimeout(() => ctrl.abort(), 11000);\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, ...(model.startsWith(\"openai/gpt-oss\") ? { reasoning_effort: \"low\" } : {}), temperature: 0.2,\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) {\n const j = await res.json();\n let txt = String(j?.choices?.[0]?.message?.content || \"\").trim();\n txt = txt.replace(/\\*\\*/g, \"*\");\n if (txt && /[A-Za-z]{3,}/.test(txt)) return txt;\n logErr(`groq ${model} bad-output: ` + txt.slice(0, 80));\n } else {\n logErr(`groq ${model} HTTP ${res.status}: ${(await res.text()).slice(0, 220)}`);\n }\n } catch (e) { logErr(`groq ${model} EXC ${String(e).slice(0, 160)}`); } finally { groqRelease(); }\n await new Promise((r) => setTimeout(r, jitter(700)));\n }\n return null;\n}\n\nasync function webSearch(q: string): Promise<{ title: string; snippet: string }[]> {\n const clean = (s: string) => s.replace(/<[^>]+>/g, \" \").replace(/&#(\\d+);/g, (_m, d) => String.fromCharCode(Number(d))).replace(/'/g, \"'\").replace(/"/g, '\"').replace(/ /g, \" \").replace(/&/g, \"&\").replace(/\\s+/g, \" \").trim();\n const UA = { \"User-Agent\": \"Mozilla/5.0 (X11; Linux x86_64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/126.0 Safari/537.36\" };\n // Source 0: Tavily (free tier, wired via env) - most reliable\n const tavilyKey = Deno.env.get(\"TAVILY_API_KEY\");\n if (tavilyKey) {\n try {\n const res = await fetch(\"https://api.tavily.com/search\", {\n method: \"POST\",\n headers: { \"Content-Type\": \"application/json\" },\n body: JSON.stringify({ api_key: tavilyKey, query: q, max_results: 5, search_depth: \"basic\" }),\n });\n if (res.ok) {\n const j = await res.json();\n const out = (j?.results || []).slice(0, 5).map((r: any) => ({ title: String(r.title || \"\"), snippet: String(r.content || \"\").slice(0, 300) })).filter((r: any) => r.title && r.snippet);\n if (out.length) return out;\n }\n } catch (_e) { /* next source */ }\n }\n // Source 1: DuckDuckGo lite\n try {\n const res = await fetch(\"https://lite.duckduckgo.com/lite/?q=\" + encodeURIComponent(q), { headers: UA });\n if (res.ok) {\n const html = await res.text();\n const out: { title: string; snippet: string }[] = [];\n const re = /class='result-link'[^>]*>([\\s\\S]*?)<\\/a>[\\s\\S]*?class='result-snippet'[^>]*>([\\s\\S]*?)<\\/td>/g;\n let m;\n while ((m = re.exec(html)) && out.length < 5) out.push({ title: clean(m[1]), snippet: clean(m[2]) });\n if (out.length) return out;\n }\n } catch (_e) { /* next source */ }\n // Source 2: Bing\n try {\n const res = await fetch(\"https://www.bing.com/search?q=\" + encodeURIComponent(q) + \"&count=6&cc=IN&mkt=en-IN&setlang=en-IN\", { headers: { ...UA, \"Accept-Language\": \"en-IN,en;q=0.9\" } });\n if (res.ok) {\n const html = await res.text();\n const out: { title: string; snippet: string }[] = [];\n const re = /]*>]*>([\\s\\S]*?)<\\/a><\\/h2>\\s*

]*>([\\s\\S]*?)<\\/p>/g;\n let m;\n while ((m = re.exec(html)) && out.length < 5) {\n const t = clean(m[1]), s = clean(m[2]);\n if (t && s) out.push({ title: t, snippet: s });\n }\n if (out.length) return out;\n }\n } catch (_e) { /* next source */ }\n return [];\n}\n\nconst normName = (s: string) => s.toLowerCase().replace(/[^a-z0-9]/g, \"\");\n\nasync function runTeaser(wa: string, business: string, history: { role: string; text: string }[]): Promise {\n await ensureTables();\n try {\n const prev = await sqlite.execute({ sql: `SELECT ts FROM ht_teaser WHERE wa_id = ?`, args: [wa] });\n const last = Number(prev.rows?.[0]?.[1] ?? 0);\n if (Date.now() - last < 86400000) return null; // one teaser per sender per day\n } catch (_e) { /* table hiccup: continue */ }\n const ctx = history.slice(-6).map((h) => h.role + \": \" + h.text).join(\" | \").slice(-600);\n const qs = await groqAsk(\n `You write realistic discovery questions. A customer who has NEVER heard of this business types these into an AI assistant (ChatGPT, Gemini etc) to FIND one. Each line: one short question about the business's CATEGORY, including the city/locality if the context mentions one (\"best dental clinic in HSR Layout\", \"root canal cost near me in Bangalore\"). HARD RULE: never include the business's own name (or any part of it) in a question. Reply with ONLY 3 plain lines - no numbering, no bullets, no quotes.`,\n `Business name (never repeat it in the questions): ${business}\\nChat context: ${ctx}`, 200);\n if (!qs) return null;\n const questions = qs.split(\"\\n\").map((s) => s.replace(/^[-*\\d.)\\s\"]+/, \"\").replace(/[\"]+$/, \"\").trim()).filter((s) => s.length > 8).slice(0, 3);\n if (!questions.length) return null;\n const answers = await Promise.all(questions.map((q) =>\n groqAsk(`You are an AI assistant helping a local customer. Answer in 1-2 sentences, naming specific real businesses when you know them. Be honest if you don't know any.`, q, 220)\n ));\n const bn = normName(business);\n const firstWord = normName(business.split(/\\s+/)[0]);\n const named = answers.map((a) => {\n if (!a) return null;\n const an = normName(a);\n return (bn.length > 2 && an.includes(bn)) || (firstWord.length > 3 && an.includes(firstWord));\n });\n const score = named.filter((n) => n === true).length;\n const detail = questions.map((q, i) => `${i + 1}) \"${q}\" - ${named[i] === null ? \"couldn't check that one\" : named[i] ? \"you're named\" : \"not named\"}`).join(\"\\n\");\n const verdict = score === 0 ? \"you're invisible there right now - that's exactly what the audit fixes\"\n : score === questions.length ? \"you're showing up everywhere, nice\"\n : \"you're getting missed on some - fixable\";\n try { await sqlite.execute({ sql: `INSERT OR REPLACE INTO ht_teaser (wa_id, ts) VALUES (?, ?)`, args: [wa, Date.now()] }); } catch (_e) { /* best effort */ }\n return `Quick live check on *${business}* - asked AI tools ${questions.length} real customer questions:\\n${detail}\\n${score}/${questions.length} - ${verdict}. The full scorecard (0-100 score, 20+ questions, screenshots, fixes) lands within a day, free.`;\n}\n\n// Deepthi's own numbers - she tests the bot live. Never leads, never lead alerts.\nconst OWNER_WAS = new Set([\"916362039431\", \"919900528568\"]);\n\n// Competitor/market lookup detector - includes the misspellings real people type.\nconst RESEARCH_RE = /competitor|competiton|comptetior|competetor|competetior|competior|comptitor|compititor|compitier|compitition|competition|competiton|comptetition|comptetion|competing|rivals?|who else|others like|alternatives?|compare|\\bvs\\b|market|nearby|(top|best|good|famous|popular)\\s+[\\w\\s]{1,30}?\\s+(in|near)\\b|reviews? of|prices? (in|near|of)|up against|near (me|us|here)|around (me|here)|in (my|our) (area|city|neighbou?rhood)|any other|other \\w{3,14}s (in|near|around)/i;\n\n// Competitor-family words are ALWAYS business-relevant (\"who is my competitor\" implies a business).\nconst COMP_RE = /competitor|competiton|comptetior|competetor|competetior|competior|comptitor|compititor|compitier|compitition|competition|competiton|comptetition|comptetion|competing|rivals?|up against|who else.*(sell|offer|do|provide)|alternatives? to (my|our)/i;\nconst FIRSTPERSON_BIZ_RE = /\\b(my|our)\\s+(business|company|brand|shop|store|salon|spa|clinic|cafe|restaurant|gym|studio|bakery|hotel|agency|startup|firm|parlou?r|boutique|pharmacy|hospital|school|academy)|\\bi (run|own|manage|started|just opened|am opening)\\b|\\bwe (run|own|manage)\\b/i;\n// Search credits are for business questions only. Generic chit-chat (best cafe, trivia) never burns one.\nfunction shouldResearch(body: string, hasBizCtx: boolean): boolean {\n if (COMP_RE.test(body)) return true;\n if (!RESEARCH_RE.test(body)) return false;\n return hasBizCtx || FIRSTPERSON_BIZ_RE.test(body);\n}\n\n// ---------------- conversation engine ----------------\nasync function doResearch(wa: string, body: string, history: { role: string; text: string }[], sess: { step: string; name: string; business: string; interest: string }, name: string, business: string, interest: string, searchq: string | null = null): Promise {\n const bizCtx = (business || sess.business || \"\").trim();\n const q = searchq || (bizCtx && !body.toLowerCase().includes(bizCtx.toLowerCase()) ? body + \" (\" + bizCtx + \")\" : body);\n let results = await webSearch(q);\n if (results.length) {\n const stop = new Set([\"the\",\"what\",\"which\",\"who\",\"are\",\"for\",\"and\",\"with\",\"from\",\"near\",\"best\",\"top\",\"good\",\"there\",\"their\",\"this\",\"that\",\"have\",\"about\",\"your\",\"mine\",\"run\",\"own\",\"other\",\"others\",\"any\",\"some\",\"else\"]);\n const terms = q.toLowerCase().replace(/[^a-z0-9\\s]/g, \" \").split(/\\s+/).filter((w) => w.length > 3 && !stop.has(w) && !/comp/i.test(w));\n const overlap = (r: { title: string; snippet: string }) => {\n const hay = (r.title + \" \" + r.snippet).toLowerCase();\n return terms.filter((t) => hay.includes(t) || (t.endsWith(\"s\") && hay.includes(t.slice(0, -1)))).length;\n };\n results = results.filter((r) => overlap(r) >= (terms.length > 2 ? 2 : 1));\n }\n if (results.length) {\n const grounded = await groqAsk(\n AI_SYSTEM + \"\\n\\nLIVE WEB RESULTS for their question - answer from these, name real names, keep your texting style, say so if the results are thin:\\n\" + results.map((r, i) => `${i + 1}. ${r.title} - ${r.snippet}`).join(\"\\n\"),\n `Recent chat: ${history.slice(-4).map((h) => h.role + \": \" + h.text).join(\" | \").slice(-400)}\\nTheir question: ${body}`, 350,\n [\"openai/gpt-oss-120b\", \"openai/gpt-oss-120b\", \"openai/gpt-oss-20b\", \"openai/gpt-oss-20b\"]);\n if (grounded && !grounded.trim().startsWith(\"HANDOFF\")) {\n if (sess.step === \"new\") await setSession(wa, \"normal\", name, business, interest);\n await addHistory(wa, \"assistant\", grounded);\n await sendReply(wa, grounded);\n return;\n }\n }\n // No usable results: be honest, never invent names.\n const sorry = pick([\n `Tried a live search and it's coming back empty on my end - I'd rather not guess names. Deepthi can pull the real list for you.`,\n `My live lookup just failed me, so I won't wing it with made-up names. Deepthi can get you the real answer.`,\n ]);\n await addHistory(wa, \"assistant\", sorry);\n await sendReply(wa, sorry);\n}\n\n\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\n // Pending lead confirmation?\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 id = leadId();\n if (!OWNER_WAS.has(wa)) {\n await sqlite.execute({ sql: `INSERT INTO ht_leads (id, wa_id, name, business, interest, ts) VALUES (?, ?, ?, ?, ?, ?)`, args: [id, wa, sess.name, sess.business, sess.interest, Date.now()] });\n await alertOwner(`New lead ${id}`, `Name: ${sess.name}\\nBusiness: ${sess.business}\\nInterested in: ${sess.interest}\\nWhatsApp: +${wa}\\nLead ID: ${id}\\n\\nReach out to set up the free audit.`);\n }\n await setSession(wa, \"done\", sess.name, sess.business, sess.interest);\n const reply = leadDone(sess.name);\n await addHistory(wa, \"assistant\", reply);\n await sendReply(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 await addHistory(wa, \"assistant\", leadDropped);\n await sendReply(wa, leadDropped);\n return;\n }\n // anything else while pending: banter gets a light nudge, never the AI\n if (/^(hi+|hello+|hey+|yo+|hiii+|ok+|okay|hmm+|lol+|nice|cool|bro|dude)[\\w\\s!.,'~]*$/i.test(body) && body.split(/\\s+/).length <= 3 && !body.includes(\"?\")) {\n const nudge = pick([\n `No rush - just say yes to lock it in, or no to drop it.`,\n `Still here! Yes to confirm, no to drop - your call.`,\n ]);\n await addHistory(wa, \"assistant\", nudge);\n await sendReply(wa, nudge);\n return;\n }\n // otherwise still try to answer via AI below\n }\n\n const parsedP = parseMessage(body, history);\n const replyP = aiReply(body, history);\n const parsed = await parsedP;\n const GREET_RE = /^(hi+|hello+|hey+|namaste|namaskara|yo|good\\s(morning|afternoon|evening|night))[\\s!.]*$/i;\n let intent = parsed?.intent ?? (GREET_RE.test(body) ? \"greeting\" : \"other\");\n if (intent === \"research\" && !shouldResearch(body, !!(parsed?.business || sess.business))) intent = \"other\";\n if (intent !== \"research\" && intent !== \"handoff\" && intent !== \"book\" && shouldResearch(body, !!(parsed?.business || sess.business))) {\n intent = \"research\";\n }\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 // Greeting on a fresh conversation: deterministic - every new sender, every time, whatever they say first.\n if (sess.step === \"new\" && history.length === 0) {\n const reply = greetingMsg(name);\n await setSession(wa, \"normal\", name, business, interest);\n await addHistory(wa, \"assistant\", reply);\n await sendReply(wa, reply);\n sess.step = \"normal\";\n if (GREET_RE.test(body) || (body.split(/\\s+/).length <= 3 && !body.includes(\"?\"))) return;\n // substantive first message: greeting is out, answer it below\n history.push({ role: \"assistant\", text: reply });\n }\n\n // Booking intent: collect what's missing, then confirm.\n if (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 await addHistory(wa, \"assistant\", ask);\n await sendReply(wa, ask);\n return;\n }\n const intr = interest || \"both\";\n const intrLabel = intr === \"receptionist\" ? \"the WhatsApp + Instagram AI receptionist\" : intr === \"visibility\" ? \"AI search visibility\" : \"both services\";\n if (intr !== \"receptionist\") {\n const t = await runTeaser(wa, business, history);\n if (t) { await addHistory(wa, \"assistant\", t); await sendReply(wa, t); }\n }\n const ask = confirmLeadAsk(name, business, intrLabel);\n await setSession(wa, \"confirm_lead\", name, business, intr);\n await addHistory(wa, \"assistant\", ask);\n await sendReply(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 === \"receptionist\" ? \"the WhatsApp + Instagram AI receptionist\" : intr === \"visibility\" ? \"AI search visibility\" : \"both services\";\n if (intr !== \"receptionist\") {\n const t = await runTeaser(wa, business, history);\n if (t) { await addHistory(wa, \"assistant\", t); await sendReply(wa, t); }\n }\n const ask = confirmLeadAsk(name, business, intrLabel);\n await setSession(wa, \"confirm_lead\", name, business, intr);\n await addHistory(wa, \"assistant\", ask);\n await sendReply(wa, ask);\n return;\n }\n\n // Explicit human request.\n if (intent === \"handoff\") {\n await alertOwner(`Human requested`, `WhatsApp: +${wa}\\nName: ${name || \"unknown\"}\\nBusiness: ${business || \"unknown\"}\\nLast message: \"${body.slice(0, 300)}\"`);\n await addHistory(wa, \"assistant\", HANDOFF_MSG);\n await sendReply(wa, HANDOFF_MSG);\n return;\n }\n\n\n // Mid-chat greeting or tiny small talk: human answer, never a pitch continuation.\n if (sess.step !== \"confirm_lead\" && sess.step !== \"collecting\" &&\n /^(hi+|hello+|hey+|yo+|hiii+|namaste|namaskara|good\\s(morning|afternoon|evening|night))\\b[\\w\\s!.,'~]*$/i.test(body) &&\n body.split(/\\s+/).length <= 3 && !body.includes(\"?\")) {\n const reply = pick([\n `Hey! What's up?`,\n `Hey hey. What can I do for you?`,\n `Yo! What's on your mind?`,\n ]);\n await addHistory(wa, \"assistant\", reply);\n await sendReply(wa, reply);\n return;\n }\n\n // Live research: competitor / market lookups, grounded in a real web search.\n if (intent === \"research\") {\n if (!(business || sess.business || \"\").trim() && (!parsed?.searchq || parsed.searchq.split(/\\s+/).filter((w) => w.replace(/[^a-zA-Z]/g, \"\").length > 3).length < 2)) {\n const askBiz = `Happy to check - what's the business called?`;\n await addHistory(wa, \"assistant\", askBiz);\n await sendReply(wa, askBiz);\n return;\n }\n await doResearch(wa, body, history, sess, name, business, interest, parsed?.searchq ?? null);\n return;\n }\n\n // Everything else: AI reply.\n let reply = await replyP;\n if (!reply) {\n await sqlite.execute({ sql: `INSERT INTO ht_outbox (wa_id, text, ts) VALUES (?, ?, ?)`, args: [wa, \"AI FAILED [\" + lastAiError + \"] for msg: \" + body.slice(0, 150), Date.now()] });\n reply = pick([\n `Ugh, my brain just froze for a second - mind sending that again?`,\n `Sorry, I zoned out there. Can you send that once more?`,\n ]);\n }\n if (reply.trim() === \"HANDOFF\" || reply.startsWith(\"HANDOFF\")) {\n if (shouldResearch(body, !!(parsed?.business || sess.business))) {\n if (!(business || sess.business || \"\").trim() && (!parsed?.searchq || parsed.searchq.split(/\\s+/).filter((w) => w.replace(/[^a-zA-Z]/g, \"\").length > 3).length < 2)) {\n const askBiz = `Happy to check - what's the business called?`;\n await addHistory(wa, \"assistant\", askBiz);\n await sendReply(wa, askBiz);\n return;\n }\n await doResearch(wa, body, history, sess, name, business, interest, parsed?.searchq ?? null);\n return;\n }\n await alertOwner(`Question needs a human`, `WhatsApp: +${wa}\\nName: ${name || \"unknown\"}\\nBusiness: ${business || \"unknown\"}\\nQuestion: \"${body.slice(0, 300)}\"`);\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 sendReply(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 || challenge) {\n try {\n await ensureTables();\n const ok = mode === \"subscribe\" && token === VERIFY_TOKEN && !!challenge;\n await sqlite.execute({ sql: `INSERT INTO ht_outbox (wa_id, text, ts) VALUES (?, ?, ?)`, args: [\"META-VERIFY\", (ok ? \"OK \" : \"REJECTED \") + \"mode=\" + mode + \" token=\" + token + \" challenge=\" + String(challenge).slice(0, 20), Date.now()] });\n if (ok) return new Response(challenge, { status: 200 });\n } catch (_e) { /* fall through */ }\n }\n // Deepthi's web inbox: thread list + full history + reply-as-business. Key-gated.\n if (url.searchParams.get(\"inbox\") !== null) {\n if (url.searchParams.get(\"inbox\") !== INBOX_KEY) return new Response(\"Not found\", { status: 404 });\n await ensureTables();\n const thread = url.searchParams.get(\"thread\") || \"\";\n const esc = (s: string) => String(s).replace(/&/g, \"&\").replace(//g, \">\").replace(/\"/g, \""\");\n const fmt = (ts: number) => new Date(Number(ts)).toLocaleString(\"en-IN\", { timeZone: \"Asia/Kolkata\", day: \"numeric\", month: \"short\", hour: \"numeric\", minute: \"2-digit\" });\n const label = (w: string) => w.startsWith(\"ig:\") ? \"IG \" + w.slice(3) : \"+\" + w;\n const HEAD = `HeyTrill Inbox`;\n if (!thread) {\n const q = await sqlite.execute(`SELECT h.wa_id, MAX(h.ts) AS lt, (SELECT text FROM ht_history h2 WHERE h2.wa_id = h.wa_id ORDER BY ts DESC LIMIT 1) AS last_text, s.name, s.business FROM ht_history h LEFT JOIN ht_sessions s ON s.wa_id = h.wa_id WHERE h.wa_id NOT LIKE '9199%' AND h.wa_id NOT LIKE 'ig:9199%' AND h.wa_id NOT LIKE '9190000%' GROUP BY h.wa_id ORDER BY lt DESC LIMIT 100`);\n const mres = await sqlite.execute(`SELECT wa_id FROM ht_muted`);\n const mutedSet = new Set(mres.rows.map((r: any) => String(r[0])));\n let rows = \"\";\n for (const r of q.rows) {\n const w = String(r[0]);\n const nm = (r[3] || r[4]) ? `${esc(String(r[3] || \"\"))}${r[4] ? \" (\" + esc(String(r[4])) + \")\" : \"\"} · ` : \"\";\n rows += `${fmt(Number(r[1]))}

${nm}${esc(label(w))}${mutedSet.has(w) ? 'MUTED - you' : \"\"}

${esc(String(r[2] || \"\").slice(0, 90))}

`;\n }\n return new Response(HEAD + `

HeyTrill Inbox

` + (rows || '

No conversations yet

') + ``, { headers: { \"Content-Type\": \"text/html; charset=utf-8\" } });\n }\n const mres2 = await sqlite.execute({ sql: `SELECT wa_id FROM ht_muted WHERE wa_id = ?`, args: [thread] });\n const h = await sqlite.execute({ sql: `SELECT role, text, ts FROM ht_history WHERE wa_id = ? ORDER BY ts DESC LIMIT 200`, args: [thread] });\n let msgs = \"\";\n for (const r of h.rows.reverse()) {\n msgs += `

${esc(String(r[1]))}

${fmt(Number(r[2]))}

`;\n }\n const muteNote = mres2.rows.length ? `

Thread is MUTED - bot stays silent here, you're in charge.

` : `

Bot is live in this thread - it'll also answer new messages. Mute on IG with \"it's deepthi\".

`;\n return new Response(HEAD + `

← ${esc(label(thread))}

` + msgs + muteNote +\n ``, { headers: { \"Content-Type\": \"text/html; charset=utf-8\" } });\n }\n // debug/diagnostics\n if (url.searchParams.get(\"rawfetch\") && url.searchParams.get(\"key\") === \"heytrill2026\") {\n try {\n const r = await fetch(url.searchParams.get(\"rawfetch\") || \"\", { headers: { \"User-Agent\": \"Mozilla/5.0 (X11; Linux x86_64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/126.0 Safari/537.36\" } });\n const t = await r.text();\n const i = t.search(/result|b_algo/i);\n return Response.json({ status: r.status, len: t.length, classes: (t.match(/class=\"[^\"]{1,40}\"/g) || []).slice(0, 60), around: i >= 0 ? t.slice(Math.max(0, i - 100), i + 900) : t.slice(0, 400) });\n } catch (e) { return Response.json({ error: String(e) }); }\n }\n if (url.searchParams.get(\"graph\") && url.searchParams.get(\"key\") === \"heytrill2026\") {\n const tok = url.searchParams.get(\"tok\") || Deno.env.get(\"META_TOKEN\") || \"\";\n const gp = url.searchParams.get(\"graph\") || \"/me\";\n const method = url.searchParams.get(\"method\") || \"GET\";\n const body = url.searchParams.get(\"body\");\n const r = await fetch(\"https://graph.facebook.com/v21.0\" + gp + (gp.includes(\"?\") ? \"&\" : \"?\") + \"access_token=\" + tok, {\n method,\n headers: { \"Content-Type\": \"application/json\" },\n ...(body ? { body } : {}),\n });\n const j = await r.json().catch(() => null);\n return Response.json({ status: r.status, result: j });\n }\n if (url.searchParams.get(\"groqmodels\") && url.searchParams.get(\"key\") === \"heytrill2026\") {\n const key3 = Deno.env.get(\"GROQ_API_KEY\");\n const r = await fetch(\"https://api.groq.com/openai/v1/models\", { headers: { \"Authorization\": `Bearer ${key3}` } });\n const j = await r.json();\n return Response.json({ status: r.status, models: (j?.data || []).map((m: any) => m.id) });\n }\n if (url.searchParams.get(\"groqprobe\") && url.searchParams.get(\"key\") === \"heytrill2026\") {\n const key2 = Deno.env.get(\"GROQ_API_KEY\");\n const out: Record = {};\n for (const m of (url.searchParams.get(\"groqprobe\") || \"\").split(\",\")) {\n try {\n const r = await fetch(\"https://api.groq.com/openai/v1/chat/completions\", {\n method: \"POST\",\n headers: { \"Authorization\": `Bearer ${key2}`, \"Content-Type\": \"application/json\" },\n body: JSON.stringify({ model: m, max_completion_tokens: 8, messages: [{ role: \"user\", content: \"say ok\" }] }),\n });\n out[m] = r.status + (r.ok ? \" ok\" : \" \" + (await r.text()).slice(0, 140));\n } catch (e) { out[m] = \"throw \" + String(e).slice(0, 100); }\n }\n return Response.json(out);\n }\n if (url.searchParams.get(\"searchtest\") && url.searchParams.get(\"key\") === \"heytrill2026\") {\n const r = await webSearch(url.searchParams.get(\"searchtest\") || \"test\");\n return Response.json({ count: r.length, results: r });\n }\n const histKey = url.searchParams.get(\"hist\");\n if (histKey !== null && url.searchParams.get(\"key\") === \"heytrill2026\") {\n await ensureTables();\n const like = histKey + \"%\";\n const h = await sqlite.execute({ sql: `SELECT wa_id, role, substr(text,1,220) AS text, ts FROM ht_history WHERE wa_id LIKE ? ORDER BY ts DESC LIMIT 40`, args: [like] });\n const o = await sqlite.execute({ sql: `SELECT * FROM ht_outbox WHERE wa_id LIKE ? ORDER BY ts DESC LIMIT 20`, args: [like] });\n const s = await sqlite.execute({ sql: `SELECT * FROM ht_sessions WHERE wa_id LIKE ? LIMIT 5`, args: [like] });\n const p = await sqlite.execute(`SELECT msg_id, ts FROM ht_processed WHERE msg_id LIKE 'ig_%' ORDER BY ts DESC LIMIT 20`);\n const m = await sqlite.execute({ sql: `SELECT wa_id, ts FROM ht_muted WHERE wa_id LIKE ?`, args: [like] });\n return Response.json({ history: h.rows, outbox: o.rows, sessions: s.rows, ig_processed: p.rows, muted: m.rows });\n }\n if (url.searchParams.get(\"visiontest\") && url.searchParams.get(\"key\") === \"heytrill2026\") {\n const u = url.searchParams.get(\"visiontest\") || \"\";\n const fb = await fetchBytes(u);\n const desc = fb ? await geminiDescribe(fb.bytes, fb.mime) : null;\n return Response.json({ ok: !!desc, mime: fb?.mime || null, bytes: fb?.bytes.length || 0, description: desc });\n }\n if (url.searchParams.get(\"geminimodels\") && url.searchParams.get(\"key\") === \"heytrill2026\") {\n const key = Deno.env.get(\"GEMINI_API_KEY\") || \"\";\n if (!key) return Response.json({ env_set: false });\n const r = await fetch(`https://generativelanguage.googleapis.com/v1beta/models?key=${key}&pageSize=100`);\n const t = await r.text();\n try {\n const j = JSON.parse(t);\n const names = (j.models || []).filter((m: any) => (m.supportedGenerationMethods || []).includes(\"generateContent\")).map((m: any) => m.name);\n return Response.json({ env_set: true, http: r.status, models: names });\n } catch { return Response.json({ env_set: true, http: r.status, raw: t.slice(0, 400) }); }\n }\n if (url.searchParams.get(\"audiotest\") && url.searchParams.get(\"key\") === \"heytrill2026\") {\n const u = url.searchParams.get(\"audiotest\") || \"\";\n const t = await transcribeFromUrl(u);\n return Response.json({ ok: !!t, transcript: t });\n }\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 const history = await sqlite.execute(`SELECT wa_id, role, text, ts FROM ht_history ORDER BY ts DESC LIMIT 80`);\n const processed = await sqlite.execute(`SELECT COUNT(*) FROM ht_processed`);\n return Response.json({ sessions: sessions.rows, leads: leads.rows, outbox: outbox.rows, history: history.rows, errlog: (await sqlite.execute(`SELECT msg, ts FROM ht_errlog ORDER BY ts DESC LIMIT 30`)).rows, processed_count: processed.rows?.[0]?.[0], meta_configured: !!(META_TOKEN && PHONE_NUMBER_ID), groq_configured: !!Deno.env.get(\"GROQ_API_KEY\") });\n }\n return new Response(\"heytrill receptionist ok\");\n }\n\n if (req.method !== \"POST\") return new Response(\"ok\");\n\n // Inbox reply-as-business (form POST)\n if ((req.headers.get(\"content-type\") || \"\").includes(\"application/x-www-form-urlencoded\")) {\n const form = new URLSearchParams(await req.text());\n if (form.get(\"inbox\") !== INBOX_KEY) return new Response(\"Not found\", { status: 404 });\n const th = String(form.get(\"thread\") || \"\");\n const tx = String(form.get(\"text\") || \"\").trim().slice(0, 900);\n if (th && tx) {\n await ensureTables();\n // Dedupe guard: identical text to the same thread within 2 min = skip the resend (protects against repeated form taps on a slow page).\n const dup = await sqlite.execute({ sql: `SELECT COUNT(*) FROM ht_history WHERE wa_id = ? AND role = 'assistant' AND text = ? AND ts > ?`, args: [th, tx, Date.now() - 120000] });\n if (!Number(dup.rows?.[0]?.[0] || 0)) {\n await sendReply(th, tx);\n await addHistory(th, \"assistant\", tx);\n }\n }\n return new Response(null, { status: 303, headers: { \"Location\": `/?inbox=${INBOX_KEY}&thread=${encodeURIComponent(th)}` } });\n }\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 if (payload && payload.test === true) {\n const wa = String(payload.from || \"919999999999\");\n const body = String(payload.body || \"\");\n await ensureTables();\n captureMap.set(wa, []);\n try {\n await handleMessage(wa, body);\n } finally {\n var texts = (captureMap.get(wa) || []).slice();\n captureMap.delete(wa);\n }\n return Response.json({ replies: texts });\n }\n\n // Instagram Messaging webhook\n try {\n if (payload?.object === \"instagram\") {\n for (const entry of payload?.entry ?? []) {\n for (const ev of entry?.messaging ?? []) {\n if (!ev?.message) continue; // reads, reactions, delivery receipts: no message body, ignore silently\n const sender = String(ev?.sender?.id || \"\");\n const mid = String(ev?.message?.mid || ev?.timestamp || \"\");\n if (!sender || !mid) continue;\n if (ev?.message?.is_echo) {\n // Deepthi typing from the @heytrill.team side: human takeover / release codes.\n // \"it's deepthi\" (also: its deepthi / it is deepthi / this is deepthi) mutes the bot in that thread.\n // \"bot on\" (also: resume bot) releases it. Echo sender is the business account; the customer is the recipient.\n const echoText = String(ev?.message?.text || \"\").trim().toLowerCase().replace(/[\\u2018\\u2019]/g, \"'\");\n const peer = String(ev?.recipient?.id || \"\");\n if (peer && /(it'?s|it is|this is)\\s+deepthi\\b/.test(echoText)) {\n await markProcessed(\"ig_\" + mid);\n await setMuted(\"ig:\" + peer, true);\n logErr(`IG takeover: ig:${peer} muted (owner code)`);\n } else if (peer && /^(bot\\s+on|resume\\s+bot)[.! ]*$/.test(echoText)) {\n await markProcessed(\"ig_\" + mid);\n await setMuted(\"ig:\" + peer, false);\n logErr(`IG takeover released: ig:${peer} unmuted (owner code)`);\n } else if (peer && echoText.includes(\"deepthi\")) {\n logErr(`IG echo with 'deepthi' but no code match: \"` + echoText.slice(0, 60) + `\"`);\n }\n continue; // all other echoes: our own sends mirrored back\n }\n if (await alreadyProcessed(\"ig_\" + mid)) continue;\n await markProcessed(\"ig_\" + mid);\n const text = ev?.message?.text;\n // Resolve media: voice notes -> transcript; photos -> ack (no vision model on free tier yet)\n let body = text ? String(text) : \"\";\n let mediaKind = \"\";\n if (!body) {\n const atts = ev?.message?.attachments ?? [];\n const audio = atts.find((a: any) => a?.type === \"audio\" && a?.payload?.url);\n const image = atts.find((a: any) => a?.type === \"image\" && a?.payload?.url);\n if (audio) {\n mediaKind = \"audio\";\n const tr = await transcribeFromUrl(String(audio.payload.url));\n body = tr || \"\";\n if (!tr) mediaKind = \"audio_fail\";\n } else if (image) {\n mediaKind = \"image\";\n const fb = await fetchBytes(String(image.payload.url));\n const desc = fb ? await geminiDescribe(fb.bytes, fb.mime) : null;\n if (desc) { body = `[Customer sent a photo. What it shows]: ${desc}\\n(Reply helpfully about the photo based on this description. This description is all you know about it - never claim to see more.)`; mediaKind = \"image_described\"; }\n }\n }\n // Story replies: answer with the story's context, not a cold greeting\n const story = ev?.message?.reply_to?.story;\n if (story && body) {\n const storyUrl = String(story?.url || \"\");\n let storyDesc = \"\";\n if (storyUrl) {\n const sfb = await fetchBytes(storyUrl);\n if (sfb && sfb.mime.startsWith(\"image/\")) {\n const sd = await geminiDescribe(sfb.bytes, sfb.mime);\n if (sd) storyDesc = ` Our story shows: ${sd}`;\n }\n }\n body = `[This message is their reply to our Instagram story${storyUrl ? \" (story link: \" + storyUrl + \")\" : \"\"}.${storyDesc} Treat it as a reaction to that story - respond to what they said with the story in mind, not as a cold first DM.]\\n` + body;\n mediaKind = mediaKind || \"story_reply\";\n }\n if (await isMuted(\"ig:\" + sender)) {\n // Deepthi is handling this thread herself - stay silent, keep the customer's messages in history for context.\n await addHistory(\"ig:\" + sender, \"user\", body || (mediaKind ? \"(\" + mediaKind + \" message)\" : \"(non-text message)\"));\n continue;\n }\n if (mediaKind === \"audio_fail\") {\n await sendIG(sender, VOICE_FAIL_MSG);\n } else if (mediaKind === \"image\") {\n await sendIG(sender, PHOTO_MSG);\n } else if (body) {\n await handleMessage(\"ig:\" + sender, body);\n } else {\n await sendIG(sender, `Sorry, I can only read text and voice notes for now - could you type that out?`);\n }\n }\n }\n // Post comments: public auto-reply in brand voice via the salonbot comment relay (its Instagram-login token).\n const OWN_IG = Deno.env.get(\"IG_USER_ID\") || \"17841425565466394\";\n for (const entry of payload?.entry ?? []) {\n for (const ch of entry?.changes ?? []) {\n if (ch?.field !== \"comments\" && ch?.field !== \"live_comments\") continue;\n const v = ch?.value;\n const cid = String(v?.id || \"\");\n const ctext = String(v?.text || \"\").trim();\n const fromId = String(v?.from?.id || \"\");\n const fromUser = String(v?.from?.username || \"\");\n if (!cid || !ctext) continue;\n if (fromUser.toLowerCase() === \"heytrill.team\" || (fromId && fromId === OWN_IG)) continue; // our own comments\n if (await alreadyProcessed(\"igc_\" + cid)) continue;\n await markProcessed(\"igc_\" + cid);\n if (fromId && await isMuted(\"ig:\" + fromId)) continue; // takeover consistency: muted customer = silent bot\n const reply = await answerComment(fromUser, ctext);\n if (!reply) { logErr(`comment ai fail for ${cid}: \"${ctext.slice(0, 80)}\"`); continue; }\n const flagged = reply.startsWith(\"FLAG:\");\n const publicReply = (flagged ? reply.slice(5) : reply).trim();\n if (publicReply) {\n try {\n const rr = await fetch(\"https://deepthisudhakar023--cc5c8056acfb11f1a2541607ee4eb77e.web.val.run\", {\n method: \"POST\",\n headers: { \"Content-Type\": \"application/json\" },\n body: JSON.stringify({ igcomment: \"heytrill2026\", comment_id: cid, text: publicReply }),\n });\n const rt = await rr.text();\n await sqlite.execute({ sql: `INSERT INTO ht_outbox (wa_id, text, ts) VALUES (?, ?, ?)`, args: [\"igc:\" + fromUser, \"COMMENT REPLY (\" + rr.status + \") \" + rt.slice(0, 120) + \" :: \" + publicReply.slice(0, 160), Date.now()] });\n } catch (e) { logErr(`comment relay throw: ${String(e).slice(0, 120)}`); }\n }\n if (flagged) {\n await sendWhatsApp(\"916362039431\", `IG comment from @${fromUser || fromId} needs you: \"${ctext.slice(0, 180)}\" - I replied publicly: \"${publicReply.slice(0, 180)}\"`);\n }\n }\n }\n return new Response(\"ok\", { status: 200 });\n }\n } catch (err) {\n logErr(\"ig webhook error: \" + String(err).slice(0, 300));\n return new Response(\"ig webhook error: \" + String(err), { 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 // Coexistence guard: with the WA Business app linked to this number, Deepthi's app-side\n // sends echo back through the webhook. Never treat our own number as a customer - the bot\n // would reply to itself / double-answer threads she's handling manually.\n if (wa.replace(/\\D/g, \"\").endsWith(\"917026370052\")) { await markProcessed(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 if ((msg?.type === \"audio\" || msg?.type === \"voice\") && msg?.audio?.id) {\n const murl = await waMediaUrl(String(msg.audio.id));\n const tr = murl ? await transcribeFromUrl(murl, `Bearer ${META_TOKEN}`) : null;\n if (tr) await handleMessage(wa, tr);\n else await sendReply(wa, VOICE_FAIL_MSG);\n } else if (msg?.type === \"image\") {\n const caption = String(msg?.image?.caption || \"\").trim();\n let desc: string | null = null;\n if (msg?.image?.id) {\n const murl = await waMediaUrl(String(msg.image.id));\n const fb = murl ? await fetchBytes(murl, `Bearer ${META_TOKEN}`) : null;\n desc = fb ? await geminiDescribe(fb.bytes, fb.mime) : null;\n }\n if (desc) {\n const composed = (caption ? caption + \"\\n\" : \"\") + `[Customer sent a photo. What it shows]: ${desc}\\n(Reply helpfully about the photo based on this description. This description is all you know about it - never claim to see more.)`;\n await handleMessage(wa, composed);\n }\n else if (caption) await handleMessage(wa, caption + \"\\n(they attached a photo too - you cannot see images yet, never pretend you can; answer the text and ask what the photo shows if it matters)\");\n else await sendReply(wa, PHOTO_MSG);\n } else {\n const fallback = `Sorry, I can only read text and voice notes for now - could you type that out?`;\n await sendReply(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}","fileType","http",68,"parentId","createdAt",["D",1789222609165],"branchVersion",69,"label",[19],{"_33":34,"_13":19,"_37":38,"_44":-5,"_35":36,"_47":48,"_52":53,"_45":54,"_17":43,"_41":42,"_39":40,"_55":56,"_49":-5,"_57":58,"_18":59},"latest",true,["D",1789222609165],"deleted",false,"children",[],[19],"b5605dd9-ac6e-4d54-bf4f-b4694c9aec3a",["D",1789033259776],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","imageUrl","userId","a7b0a2c2-1be4-4203-9fcd-83311077f65b","pinnedFileId","pinPreview","pinMigrated","screenshotVersion","likeCount",0,"orgId","01a0709c-b2b2-772d-ba3f-c6e0c645cf6d","tursoName","tursoHostname","tursoMeasuredAt","pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_11":12,"_113":108},"org",{"_11":12,"_107":108,"_109":108,"_69":70,"_110":111,"_112":56},"branch",{"_17":48,"_13":16,"_33":36,"_99":60,"_100":-5,"_101":-5,"_102":-5,"_103":-5,"_104":-5,"_105":14,"_106":12},"isOwned","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","displayName","","avatar","tier","free","canRestrictVals","profileImageUrl","adoptOrgId",{"_33":60,"_13":14,"_45":149,"_62":-5,"_63":56,"_64":65,"_66":65,"_67":-5,"_68":-5,"_69":70,"_71":38,"_72":53,"_73":-5,"_74":-5,"_75":76,"_77":78,"_79":-5,"_80":-5,"_81":-5,"_82":-5,"_83":84,"_85":84,"_86":87,"_88":87,"_89":87,"_90":84,"_91":84,"_92":150,"_94":151,"_96":152,"_98":56},[146],"files",[146],"counts",{"_135":76,"_136":137,"_138":76,"_32":139,"_140":141},[],{"_33":34,"_35":36,"_37":38,"_13":19,"_39":40,"_41":42,"_17":43,"_44":-5,"_45":133,"_47":48,"_49":-5,"_18":134},"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},["D",1789222609165],[19],"pulls","branches",1,"forks",{"_142":144,"_145":76},"connections",{"_142":76,"_143":76},"count","unfilledCount",8,"emptyCount",{"_33":34,"_13":19,"_37":38,"_44":-5,"_35":36,"_47":48,"_52":53,"_45":54,"_17":43,"_41":42,"_39":40,"_55":56,"_49":-5,"_57":147,"_18":148},[],[19],["D",1789033259776],{"_11":12,"_113":108},{"_11":12,"_107":108,"_109":108,"_69":70,"_110":111,"_112":56},{"_17":48,"_13":16,"_33":36,"_99":60,"_100":-5,"_101":-5,"_102":-5,"_103":-5,"_104":-5,"_105":14,"_106":12},"ctx",{"_92":-5,"_130":186,"_187":188,"_189":190,"_191":56,"_192":56,"_193":56,"_194":53,"_195":-5,"_196":-7,"_197":-7,"_198":76,"_199":56,"_200":56,"_201":-5,"_202":56,"_203":56,"_204":56,"_205":-5},"ENV",{"_157":158,"_159":160,"_161":16,"_162":163,"_164":165,"_166":167,"_168":169,"_170":171,"_172":173,"_174":175,"_176":177,"_178":179,"_180":181,"_182":183,"_184":185},"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",[],"preferencesKeybindings","default","preferencesTheme","light","preferencesFixers","preferencesCopilot","preferencesSelectionAi","preferencesCloseBrackets","preferencesChatPanelState","preferencesDprint","preferencesDenofmt","notificationCount","flagDenols","isBusinessOrgMember","businessOrgHandle","isBusinessOrgAdmin","isHigherTownieTier","navCollapsed","currentOrgId"]