HeyTrill Inbox

]*>([\\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}","deleted","label",[113],"pulls",1,"forks","envVars",{"_135":137,"_138":53},"connections",{"_135":53,"_136":53},"count","unfilledCount",8,"emptyCount",{"_20":112,"_13":113,"_114":47,"_115":-5,"_116":21,"_117":30,"_118":49,"_22":140,"_29":120,"_121":122,"_123":124,"_125":38,"_126":-5,"_141":142,"_89":143},["D",1789222609165],"children",[],[113],["D",1789033259776],{"_11":12,"_87":82},{"_11":12,"_81":82,"_83":82,"_44":45,"_84":85,"_86":38},{"_29":30,"_13":26,"_20":21,"_27":28,"_31":-5,"_32":-5,"_76":-5,"_77":-5,"_78":-5,"_79":14,"_80":12},"ctx",{"_69":-5,"_108":181,"_182":183,"_184":185,"_186":38,"_187":38,"_188":38,"_189":49,"_190":-5,"_191":-7,"_192":-7,"_193":53,"_194":38,"_195":38,"_196":-5,"_197":38,"_198":38,"_199":38,"_200":-5},"ENV",{"_152":153,"_154":155,"_156":26,"_157":158,"_159":160,"_161":162,"_163":164,"_165":166,"_167":168,"_169":170,"_171":172,"_173":174,"_175":176,"_177":178,"_179":180},"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"]

Branches1

Branches
1