[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_193":194,"_195":196},"routes/_app.x.$handle.$name",{"_99":98,"_32":45,"_107":89,"_27":101,"_13":14,"_108":-5,"_11":109,"_110":111,"_112":113,"_114":115,"_116":117,"_20":-5,"_118":-5,"_119":-5,"_120":25,"_121":122,"_123":58,"_124":-5,"_125":-5,"_126":127},"routes/_app.x.$handle.$name.branch.$branch.version.$version.diff",{"_11":12,"_13":14,"_15":16,"_17":-5,"_18":-5},"project",{"_43":44,"_32":45,"_38":46,"_47":-5,"_48":25,"_49":50,"_51":50,"_52":-5,"_53":-5,"_18":54,"_55":56,"_57":58,"_59":-5,"_60":-5,"_61":62,"_63":64,"_65":66,"_67":68,"_69":70,"_71":-5,"_72":73,"_74":73,"_75":76,"_77":76,"_78":76,"_79":73,"_80":73,"_81":82,"_83":84,"_85":86,"_87":25},"version",33,"changes",[19],"aiChatInfo","userId",{"_20":21,"_22":23,"_24":25,"_26":25,"_27":28,"_29":28},"file",{"_30":31,"_32":28,"_33":34,"_35":37,"_38":39,"_40":14,"_41":42,"_24":25},"previous",{"_30":31,"_32":28,"_33":34,"_35":36},"deleted",false,"deletedHere","path","heytrill.ts","latestPath","fileId","cc5c8056-acfb-11f1-a254-1607ee4eb77e","name","fileType","http","content","// HeyTrill AI Receptionist - WhatsApp bot on Meta Cloud API.\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 ? `Hi ${name}!` : pick([\"Hi!\", \"Hello!\", \"Hi there!\"]);\n return pick([\n `${hi} You've reached *HeyTrill*. We build WhatsApp AI receptionists for businesses, and we get brands named by ChatGPT. What can I help with?`,\n `${hi} *HeyTrill* here. We do two things: AI receptionists for WhatsApp, and AI search visibility. What's on your mind?`,\n ]);\n};\n\nconst HANDOFF_MSG = pick([\n `That's a bit outside what I can answer, so Deepthi (our founder) will reply to you here shortly. Anything else I can help with meanwhile?`,\n `Good question - that one's for Deepthi, our founder. She'll reply here shortly. Can I help with anything else in the meantime?`,\n]);\n\nconst confirmLeadAsk = (name: string, biz: string, interest: string) =>\n `Just to confirm, ${name}: you'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 WhatsApp receptionist at HeyTrill, texting with prospective clients. You sound like a real person at a small, sharp agency - warm, relaxed, plain-spoken. Answer ONLY from this real company data:\n\nABOUT HEYTRILL:\n- HeyTrill is an AI services company founded by Deepthi Sudhakar. Two services, sold worldwide.\n- Brand: \"hey\" is the first word of every customer conversation, and a trill is the bird call that carries above the noise - \"when a customer says hey, you're always heard\".\n\nSERVICE 1 - WhatsApp AI Receptionist:\n- A bot on the business's OWN WhatsApp number that answers customers instantly, 24/7: shares services and prices, takes bookings, answers questions in the customer's language, and hands over to a human when needed.\n- Includes the Sunday Brief: a weekly WhatsApp digest for the owner - bookings, missed messages, top customer questions, dead hours.\n- No app, no software to install - just WhatsApp. Fully done-for-you setup, takes about a week. The business owner never touches anything technical - we need a number not currently on WhatsApp and one verification code.\n- Pricing: founding-client offer Rs.9,999 one-time setup + Rs.3,999/month (first 5 clients). Standard rate Rs.19,999 setup + Rs.3,999/month.\n- The client keeps their own WhatsApp for themselves; the bot runs on its own number.\n\nSERVICE 2 - AI Search Visibility (GEO):\n- Getting the business named when buyers ask ChatGPT, Gemini or Perplexity what to buy. Like SEO, but for AI answers.\n- Starts with a one-off AI-visibility audit: 30-50 real buyer prompts run across the major AI tools, showing exactly where the business shows up, where it's invisible, and the specific content moves that flip it. Audit: Rs.20,000 one-off.\n- Ongoing retainer after the audit: Rs.45,000/month for the full visibility program.\n- Hook: a growing share of buyers now start at ChatGPT instead of Google. Every AI answer that names a rival is a shortlist the business never made.\n\nPROCESS FOR PROSPECTS:\n- Next step is a FREE audit / demo: Deepthi runs a real visibility test (for GEO) or walks the receptionist demo (for the bot), then a custom proposal. The bot (you) collects the prospect's name, business name, and which service they're interested in, and Deepthi reaches out on WhatsApp within a day.\n- Payment and contracts are handled by Deepthi directly - you never discuss payment methods, invoices, or contracts.\n\nSTRICT RULES:\n1. Never invent a price, discount, feature, timeline, or policy. If the answer is not in the data above, reply with exactly one word: HANDOFF\n2. Questions about the two services, pricing, what's included, how setup works, timelines, and the free audit ARE answerable from the data - answer them, do not hand off.\n3. Reply in the SAME language the customer writes in: English, Hindi, Kannada, Hinglish, or any mix. Default English.\n4. Write like a real person texting: short, varied sentences. NEVER use stock enthusiasm or AI cliches: no \"Great choice\", \"Certainly\", \"I'd be happy to\", \"Absolutely!\", \"Happy to help\", \"Great question\". Warmth comes from being direct and useful, not cheerleading. Don't end every message with a question.\n5. Emojis: most messages have none. At most one, only where it truly fits.\n6. Keep replies SHORT - 1 to 4 sentences, like a real WhatsApp message. If the answer needs structure (like a price breakdown), a short list is fine.\n7. Use the chat history. If they refer to something earlier (\"that one\", \"the audit\", \"and the bot?\"), answer with that context instead of asking again. If you know their name, use it once in a while, not every message.\n8. Small talk and pleasantries (\"how are you\", \"thanks\", \"ok\", \"nice\", \"bye\") are NOT handoffs: answer briefly like a real person, then steer back to how we can help.\n9. If they ask who you are: you're HeyTrill's AI receptionist - say so plainly, it's fine. Then point out this is literally service 1 in action.\n10. Never discuss competitors' pricing, never bad-mouth other agencies or tools. If asked to compare, describe what HeyTrill does and let it speak for itself.\n11. Never share Deepthi's personal number, email, or any internal detail. The contact path is this chat.\n12. Do not commit to discounts beyond the founding offer, custom quotes, or specific delivery dates beyond \"about a week\". Those go to Deepthi: reply HANDOFF.\n13. If someone asks for a human, wants a call, or asks for Deepthi directly: say Deepthi will reply here shortly (that's HANDOFF - reply exactly: HANDOFF).`;\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 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: \"openai/gpt-oss-120b\",\n reasoning_effort: \"low\",\n temperature: 0.3,\n max_completion_tokens: 400,\n messages: [\n { role: \"system\", content: AI_SYSTEM },\n ...history.map((h) => ({ role: h.role === \"user\" ? \"user\" : \"assistant\", content: h.text })),\n { role: \"user\", content: userText },\n ],\n }),\n signal: ctrl.signal,\n });\n clearTimeout(timer);\n if (!res.ok) return null;\n const j = await res.json();\n let txt = String(j?.choices?.[0]?.message?.content || \"\").trim();\n txt = txt.replace(/\\*\\*/g, \"*\");\n return txt || null;\n } catch (_e) {\n return null;\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 } | 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|greeting|smalltalk|handoff|other\",\"name\":\"first name|null\",\"business\":\"business name|null\",\"interest\":\"receptionist|visibility|both|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. 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 AI receptionist/bot. visibility = AI search visibility/GEO/ChatGPT ranking. both = both services. null if unclear.\n- Use recent chat context to resolve references, but extract the intent of the NEW message only.\n- Only extract what the message actually says. Use null when absent.`;\n try {\n const ctrl = new AbortController();\n const timer = setTimeout(() => ctrl.abort(), 8000);\n const res = await fetch(\"https://api.groq.com/openai/v1/chat/completions\", {\n method: \"POST\",\n headers: {\n \"Authorization\": `Bearer ${key}`,\n \"Content-Type\": \"application/json\",\n },\n body: JSON.stringify({\n model: \"openai/gpt-oss-120b\",\n reasoning_effort: \"low\",\n temperature: 0,\n max_completion_tokens: 120,\n messages: [\n { role: \"system\", content: system },\n { role: \"user\", content: history.length ? \"Recent chat:\\n\" + history.map((h) => (h.role === \"user\" ? \"Prospect\" : \"Bot\") + \": \" + h.text).join(\"\\n\") + \"\\n\\nProspect's new message: \" + userText : userText },\n ],\n }),\n signal: ctrl.signal,\n });\n clearTimeout(timer);\n if (!res.ok) return null;\n const j = await res.json();\n const txt = String(j?.choices?.[0]?.message?.content || \"\");\n const m = txt.match(/\\{[\\s\\S]*\\}/);\n if (!m) return null;\n const p = JSON.parse(m[0]);\n return {\n intent: VALID_INTENTS.includes(p.intent) ? p.intent : \"other\",\n name: typeof p.name === \"string\" && /^[A-Za-z][A-Za-z.' -]{1,29}$/.test(p.name.trim()) ? p.name.trim() : null,\n business: typeof p.business === \"string\" && p.business.trim().length >= 2 && p.business.trim().length <= 60 ? p.business.trim() : null,\n interest: VALID_INTERESTS.includes(p.interest) ? p.interest : null,\n };\n } catch (_e) {\n return null;\n }\n}\n\n// ---------------- storage ----------------\nlet tableReady = false;\nasync function ensureTables() {\n if (tableReady) return;\n await sqlite.execute(`CREATE TABLE IF NOT EXISTS ht_sessions (wa_id TEXT PRIMARY KEY, step TEXT, name TEXT, business TEXT, interest TEXT, updated_at INTEGER)`);\n await sqlite.execute(`CREATE TABLE IF NOT EXISTS ht_history (wa_id TEXT, role TEXT, text TEXT, ts INTEGER)`);\n await sqlite.execute(`CREATE TABLE IF NOT EXISTS ht_leads (id TEXT PRIMARY KEY, wa_id TEXT, name TEXT, business TEXT, interest TEXT, ts INTEGER)`);\n await sqlite.execute(`CREATE TABLE IF NOT EXISTS ht_processed (msg_id TEXT PRIMARY KEY, ts INTEGER)`);\n await sqlite.execute(`CREATE TABLE IF NOT EXISTS ht_outbox (id INTEGER PRIMARY KEY AUTOINCREMENT, wa_id TEXT, text TEXT, ts INTEGER)`);\n 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}\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 ----------------\nasync function sendWhatsApp(wa: string, text: string) {\n await ensureTables();\n if (!META_TOKEN || !PHONE_NUMBER_ID) {\n await sqlite.execute({ sql: `INSERT INTO ht_outbox (wa_id, text, ts) VALUES (?, ?, ?)`, args: [wa, text, Date.now()] });\n return;\n }\n const res = await fetch(`https://graph.facebook.com/v24.0/${PHONE_NUMBER_ID}/messages`, {\n method: \"POST\",\n headers: { \"Authorization\": `Bearer ${META_TOKEN}`, \"Content-Type\": \"application/json\" },\n body: JSON.stringify({ messaging_product: \"whatsapp\", to: wa, type: \"text\", text: { body: text } }),\n });\n if (!res.ok) {\n await sqlite.execute({ sql: `INSERT INTO ht_outbox (wa_id, text, ts) VALUES (?, ?, ?)`, args: [wa, \"SEND FAILED: \" + res.status + \" :: \" + text.slice(0, 200), Date.now()] });\n }\n}\n\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// ---------------- conversation engine ----------------\nasync function handleMessage(wa: string, bodyRaw: string): Promise {\n const body = bodyRaw.trim();\n if (!body) return;\n const sess = await getSession(wa);\n const history = await getHistory(wa);\n await addHistory(wa, \"user\", body);\n\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 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 await setSession(wa, \"done\", sess.name, sess.business, sess.interest);\n const reply = leadDone(sess.name);\n await addHistory(wa, \"assistant\", reply);\n await sendWhatsApp(wa, reply);\n return;\n }\n if (/^(n|no|nope|nah|beda|illa|venda|nahi|नहीं|ಬೇಡ|ಇಲ್ಲ)\\b/.test(body.toLowerCase())) {\n await setSession(wa, \"normal\", sess.name, sess.business, sess.interest);\n await addHistory(wa, \"assistant\", leadDropped);\n await sendWhatsApp(wa, leadDropped);\n return;\n }\n // anything else while pending: nudge once, but still try to answer via AI below\n }\n\n const parsed = await parseMessage(body, history);\n const name = parsed?.name || sess.name;\n const business = parsed?.business || sess.business;\n const interest = parsed?.interest || sess.interest;\n if (name !== sess.name || business !== sess.business || interest !== sess.interest) {\n await setSession(wa, sess.step === \"new\" ? \"normal\" : sess.step, name, business, interest);\n }\n\n // Booking intent: collect what's missing, then confirm.\n if (parsed?.intent === \"book\") {\n const missing: string[] = [];\n if (!name) missing.push(\"name\");\n if (!business) missing.push(\"business\");\n if (missing.length) {\n const ask = missing.length === 2\n ? `Happy to set that up. Can I get your name and your business name?`\n : missing[0] === \"name\"\n ? `Happy to set that up. What's your name?`\n : `Nice - and what's the business called?`;\n await setSession(wa, \"collecting\", name, business, interest || \"both\");\n await addHistory(wa, \"assistant\", ask);\n await sendWhatsApp(wa, ask);\n return;\n }\n const intr = interest || \"both\";\n const intrLabel = intr === \"receptionist\" ? \"the WhatsApp AI receptionist\" : intr === \"visibility\" ? \"AI search visibility\" : \"both services\";\n const ask = confirmLeadAsk(name, business, intrLabel);\n await setSession(wa, \"confirm_lead\", name, business, intr);\n await addHistory(wa, \"assistant\", ask);\n await sendWhatsApp(wa, ask);\n return;\n }\n\n // 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 AI receptionist\" : intr === \"visibility\" ? \"AI search visibility\" : \"both services\";\n const ask = confirmLeadAsk(name, business, intrLabel);\n await setSession(wa, \"confirm_lead\", name, business, intr);\n await addHistory(wa, \"assistant\", ask);\n await sendWhatsApp(wa, ask);\n return;\n }\n\n // Explicit human request.\n if (parsed?.intent === \"handoff\") {\n 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 sendWhatsApp(wa, HANDOFF_MSG);\n return;\n }\n\n // Greeting on a fresh conversation.\n if (parsed?.intent === \"greeting\" && sess.step === \"new\" && history.length === 0) {\n const reply = greetingMsg(name);\n await setSession(wa, \"normal\", name, business, interest);\n await addHistory(wa, \"assistant\", reply);\n await sendWhatsApp(wa, reply);\n return;\n }\n\n // Everything else: AI reply.\n let reply = await aiReply(body, history);\n if (!reply) {\n reply = greetingMsg(name); // AI unavailable: graceful, human-sounding fallback\n }\n if (reply.trim() === \"HANDOFF\" || reply.startsWith(\"HANDOFF\")) {\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 sendWhatsApp(wa, reply);\n}\n\n// ---------------- HTTP entry ----------------\nexport default async function (req: Request): Promise {\n const url = new URL(req.url);\n\n // Meta webhook verification\n if (req.method === \"GET\") {\n const mode = url.searchParams.get(\"hub.mode\");\n const token = url.searchParams.get(\"hub.verify_token\");\n const challenge = url.searchParams.get(\"hub.challenge\");\n if (mode === \"subscribe\" && token === VERIFY_TOKEN && challenge) {\n return new Response(challenge, { status: 200 });\n }\n // debug/diagnostics\n if (url.searchParams.get(\"debug\") === \"heytrill2026\") {\n await ensureTables();\n const sessions = await sqlite.execute(`SELECT * FROM ht_sessions ORDER BY updated_at DESC LIMIT 50`);\n const leads = await sqlite.execute(`SELECT * FROM ht_leads ORDER BY ts DESC LIMIT 50`);\n const outbox = await sqlite.execute(`SELECT * FROM ht_outbox ORDER BY ts DESC LIMIT 100`);\n return Response.json({ sessions: sessions.rows, leads: leads.rows, outbox: outbox.rows, meta_configured: !!(META_TOKEN && PHONE_NUMBER_ID) });\n }\n return new Response(\"heytrill receptionist ok\");\n }\n\n if (req.method !== \"POST\") return new Response(\"ok\");\n\n // Test harness: {\"test\":true,\"from\":\"91...\",\"body\":\"...\"} -> runs the engine, replies recorded in outbox, returns JSON\n let payload: any;\n try {\n payload = await req.json();\n } catch (_e) {\n return new Response(\"bad json\", { status: 400 });\n }\n\n if (payload && payload.test === true) {\n const wa = String(payload.from || \"919999999999\");\n const body = String(payload.body || \"\");\n await ensureTables();\n const before = await sqlite.execute({ sql: `SELECT COUNT(*) FROM ht_outbox`, args: [] });\n const n0 = Number(before.rows?.[0]?.[0] || 0);\n await handleMessage(wa, body);\n const after = await sqlite.execute({ sql: `SELECT text FROM ht_outbox ORDER BY id`, args: [] });\n const texts = (after.rows || []).slice(n0).map((r) => String(r[0]));\n return Response.json({ replies: texts });\n }\n\n // Meta Cloud API webhook\n try {\n for (const entry of payload?.entry ?? []) {\n for (const change of entry?.changes ?? []) {\n const value = change?.value;\n const messages = value?.messages;\n if (!Array.isArray(messages)) continue; // statuses etc: ignore\n for (const msg of messages) {\n const wa = String(msg?.from || \"\");\n const id = String(msg?.id || \"\");\n if (!wa || !id) continue;\n if (await alreadyProcessed(id)) continue;\n await markProcessed(id);\n if (msg?.type === \"text\" && msg?.text?.body) {\n await handleMessage(wa, String(msg.text.body));\n } else {\n const fallback = `Sorry, I can only read text messages for now - could you type that out?`;\n await sendWhatsApp(wa, fallback);\n }\n }\n }\n }\n } catch (err) {\n return new Response(\"error\", { status: 200 }); // always 200 so Meta doesn't retry-storm\n }\n return new Response(\"ok\", { status: 200 });\n}\n","// HeyTrill AI Receptionist - WhatsApp bot on Meta Cloud API.\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 ? `Hi ${name}!` : pick([\"Hi!\", \"Hello!\", \"Hi there!\"]);\n return pick([\n `${hi} You've reached *HeyTrill*. We build WhatsApp AI receptionists for businesses, and we get brands named by ChatGPT. What can I help with?`,\n `${hi} *HeyTrill* here. We do two things: AI receptionists for WhatsApp, and AI search visibility. What's on your mind?`,\n ]);\n};\n\nconst HANDOFF_MSG = pick([\n `That's a bit outside what I can answer, so Deepthi (our founder) will reply to you here shortly. Anything else I can help with meanwhile?`,\n `Good question - that one's for Deepthi, our founder. She'll reply here shortly. Can I help with anything else in the meantime?`,\n]);\n\nconst confirmLeadAsk = (name: string, biz: string, interest: string) =>\n `Just to confirm, ${name}: you'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 WhatsApp receptionist at HeyTrill, texting with prospective clients. You sound like a real person at a small, sharp agency - warm, relaxed, plain-spoken. Answer ONLY from this real company data:\n\nABOUT HEYTRILL:\n- HeyTrill is an AI services company founded by Deepthi Sudhakar. Two services, sold worldwide.\n- Brand: \"hey\" is the first word of every customer conversation, and a trill is the bird call that carries above the noise - \"when a customer says hey, you're always heard\".\n\nSERVICE 1 - WhatsApp AI Receptionist:\n- A bot on the business's OWN WhatsApp number that answers customers instantly, 24/7: shares services and prices, takes bookings, answers questions in the customer's language, and hands over to a human when needed.\n- Includes the Sunday Brief: a weekly WhatsApp digest for the owner - bookings, missed messages, top customer questions, dead hours.\n- No app, no software to install - just WhatsApp. Fully done-for-you setup, takes about a week. The business owner never touches anything technical - we need a number not currently on WhatsApp and one verification code.\n- Pricing: founding-client offer Rs.9,999 one-time setup + Rs.3,999/month (first 5 clients). Standard rate Rs.19,999 setup + Rs.3,999/month.\n- The client keeps their own WhatsApp for themselves; the bot runs on its own number.\n\nSERVICE 2 - AI Search Visibility (GEO):\n- Getting the business named when buyers ask ChatGPT, Gemini or Perplexity what to buy. Like SEO, but for AI answers.\n- Starts with a one-off AI-visibility audit: 30-50 real buyer prompts run across the major AI tools, showing exactly where the business shows up, where it's invisible, and the specific content moves that flip it. Audit: Rs.20,000 one-off.\n- Ongoing retainer after the audit: Rs.45,000/month for the full visibility program.\n- Hook: a growing share of buyers now start at ChatGPT instead of Google. Every AI answer that names a rival is a shortlist the business never made.\n\nPROCESS FOR PROSPECTS:\n- Next step is a FREE audit / demo: Deepthi runs a real visibility test (for GEO) or walks the receptionist demo (for the bot), then a custom proposal. The bot (you) collects the prospect's name, business name, and which service they're interested in, and Deepthi reaches out on WhatsApp within a day.\n- Payment and contracts are handled by Deepthi directly - you never discuss payment methods, invoices, or contracts.\n\nSTRICT RULES:\n1. Never invent a price, discount, feature, timeline, or policy. If the answer is not in the data above, reply with exactly one word: HANDOFF\n2. Questions about the two services, pricing, what's included, how setup works, timelines, and the free audit ARE answerable from the data - answer them, do not hand off.\n3. Reply in the SAME language the customer writes in: English, Hindi, Kannada, Hinglish, or any mix. Default English.\n4. Write like a real person texting: short, varied sentences. NEVER use stock enthusiasm or AI cliches: no \"Great choice\", \"Certainly\", \"I'd be happy to\", \"Absolutely!\", \"Happy to help\", \"Great question\". Warmth comes from being direct and useful, not cheerleading. Don't end every message with a question.\n5. Emojis: most messages have none. At most one, only where it truly fits.\n6. Keep replies SHORT - 1 to 4 sentences, like a real WhatsApp message. If the answer needs structure (like a price breakdown), a short list is fine.\n7. Use the chat history. If they refer to something earlier (\"that one\", \"the audit\", \"and the bot?\"), answer with that context instead of asking again. If you know their name, use it once in a while, not every message.\n8. Small talk and pleasantries (\"how are you\", \"thanks\", \"ok\", \"nice\", \"bye\") are NOT handoffs: answer briefly like a real person, then steer back to how we can help.\n9. If they ask who you are: you're HeyTrill's AI receptionist - say so plainly, it's fine. Then point out this is literally service 1 in action.\n10. Never discuss competitors' pricing, never bad-mouth other agencies or tools. If asked to compare, describe what HeyTrill does and let it speak for itself.\n11. Never share Deepthi's personal number, email, or any internal detail. The contact path is this chat.\n12. Do not commit to discounts beyond the founding offer, custom quotes, or specific delivery dates beyond \"about a week\". Those go to Deepthi: reply HANDOFF.\n13. If someone asks for a human, wants a call, or asks for Deepthi directly: say Deepthi will reply here shortly (that's HANDOFF - reply exactly: HANDOFF).`;\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 try {\n const ctrl = new AbortController();\n const timer = setTimeout(() => ctrl.abort(), 12000);\n const res = await fetch(\"https://api.groq.com/openai/v1/chat/completions\", {\n method: \"POST\",\n headers: {\n \"Authorization\": `Bearer ${key}`,\n \"Content-Type\": \"application/json\",\n },\n body: JSON.stringify({\n model: \"openai/gpt-oss-120b\",\n reasoning_effort: \"low\",\n temperature: 0.3,\n max_completion_tokens: 400,\n messages: [\n { role: \"system\", content: AI_SYSTEM },\n ...history.map((h) => ({ role: h.role === \"user\" ? \"user\" : \"assistant\", content: h.text })),\n { role: \"user\", content: userText },\n ],\n }),\n signal: ctrl.signal,\n });\n clearTimeout(timer);\n if (!res.ok) return null;\n const j = await res.json();\n let txt = String(j?.choices?.[0]?.message?.content || \"\").trim();\n txt = txt.replace(/\\*\\*/g, \"*\");\n return txt || null;\n } catch (_e) {\n return null;\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 } | 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|greeting|smalltalk|handoff|other\",\"name\":\"first name|null\",\"business\":\"business name|null\",\"interest\":\"receptionist|visibility|both|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. 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 AI receptionist/bot. visibility = AI search visibility/GEO/ChatGPT ranking. both = both services. null if unclear.\n- Use recent chat context to resolve references, but extract the intent of the NEW message only.\n- Only extract what the message actually says. Use null when absent.`;\n try {\n const ctrl = new AbortController();\n const timer = setTimeout(() => ctrl.abort(), 8000);\n const res = await fetch(\"https://api.groq.com/openai/v1/chat/completions\", {\n method: \"POST\",\n headers: {\n \"Authorization\": `Bearer ${key}`,\n \"Content-Type\": \"application/json\",\n },\n body: JSON.stringify({\n model: \"openai/gpt-oss-120b\",\n reasoning_effort: \"low\",\n temperature: 0,\n max_completion_tokens: 120,\n messages: [\n { role: \"system\", content: system },\n { role: \"user\", content: history.length ? \"Recent chat:\\n\" + history.map((h) => (h.role === \"user\" ? \"Prospect\" : \"Bot\") + \": \" + h.text).join(\"\\n\") + \"\\n\\nProspect's new message: \" + userText : userText },\n ],\n }),\n signal: ctrl.signal,\n });\n clearTimeout(timer);\n if (!res.ok) return null;\n const j = await res.json();\n const txt = String(j?.choices?.[0]?.message?.content || \"\");\n const m = txt.match(/\\{[\\s\\S]*\\}/);\n if (!m) return null;\n const p = JSON.parse(m[0]);\n return {\n intent: VALID_INTENTS.includes(p.intent) ? p.intent : \"other\",\n name: typeof p.name === \"string\" && /^[A-Za-z][A-Za-z.' -]{1,29}$/.test(p.name.trim()) ? p.name.trim() : null,\n business: typeof p.business === \"string\" && p.business.trim().length >= 2 && p.business.trim().length <= 60 ? p.business.trim() : null,\n interest: VALID_INTERESTS.includes(p.interest) ? p.interest : null,\n };\n } catch (_e) {\n return null;\n }\n}\n\n// ---------------- storage ----------------\nlet tableReady = false;\nasync function ensureTables() {\n if (tableReady) return;\n await sqlite.execute(`CREATE TABLE IF NOT EXISTS ht_sessions (wa_id TEXT PRIMARY KEY, step TEXT, name TEXT, business TEXT, interest TEXT, updated_at INTEGER)`);\n await sqlite.execute(`CREATE TABLE IF NOT EXISTS ht_history (wa_id TEXT, role TEXT, text TEXT, ts INTEGER)`);\n await sqlite.execute(`CREATE TABLE IF NOT EXISTS ht_leads (id TEXT PRIMARY KEY, wa_id TEXT, name TEXT, business TEXT, interest TEXT, ts INTEGER)`);\n await sqlite.execute(`CREATE TABLE IF NOT EXISTS ht_processed (msg_id TEXT PRIMARY KEY, ts INTEGER)`);\n await sqlite.execute(`CREATE TABLE IF NOT EXISTS ht_outbox (id INTEGER PRIMARY KEY AUTOINCREMENT, wa_id TEXT, text TEXT, ts INTEGER)`);\n 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}\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 ----------------\nasync function sendWhatsApp(wa: string, text: string) {\n await ensureTables();\n if (!META_TOKEN || !PHONE_NUMBER_ID) {\n await sqlite.execute({ sql: `INSERT INTO ht_outbox (wa_id, text, ts) VALUES (?, ?, ?)`, args: [wa, text, Date.now()] });\n return;\n }\n const res = await fetch(`https://graph.facebook.com/v24.0/${PHONE_NUMBER_ID}/messages`, {\n method: \"POST\",\n headers: { \"Authorization\": `Bearer ${META_TOKEN}`, \"Content-Type\": \"application/json\" },\n body: JSON.stringify({ messaging_product: \"whatsapp\", to: wa, type: \"text\", text: { body: text } }),\n });\n if (!res.ok) {\n await sqlite.execute({ sql: `INSERT INTO ht_outbox (wa_id, text, ts) VALUES (?, ?, ?)`, args: [wa, \"SEND FAILED: \" + res.status + \" :: \" + text.slice(0, 200), Date.now()] });\n }\n}\n\nasync function alertOwner(subject: string, text: string) {\n try {\n await email({ subject: `${OWNER_NOTE}: ${subject}`, text });\n } catch (_e) { /* best effort */ }\n}\n\nlet lastPath = \"?\";\n// ---------------- conversation engine ----------------\nasync function handleMessage(wa: string, bodyRaw: string): Promise {\n const body = bodyRaw.trim();\n if (!body) return;\n const sess = await getSession(wa);\n const history = await getHistory(wa);\n await addHistory(wa, \"user\", body);\n\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 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 await setSession(wa, \"done\", sess.name, sess.business, sess.interest);\n const reply = leadDone(sess.name);\n lastPath = \"lead_saved\";\n await addHistory(wa, \"assistant\", reply);\n await sendWhatsApp(wa, reply);\n return;\n }\n if (/^(n|no|nope|nah|beda|illa|venda|nahi|नहीं|ಬೇಡ|ಇಲ್ಲ)\\b/.test(body.toLowerCase())) {\n await setSession(wa, \"normal\", sess.name, sess.business, sess.interest);\n lastPath = \"lead_dropped\";\n await addHistory(wa, \"assistant\", leadDropped);\n await sendWhatsApp(wa, leadDropped);\n return;\n }\n // anything else while pending: nudge once, but still try to answer via AI below\n }\n\n const parsed = await parseMessage(body, history);\n const name = parsed?.name || sess.name;\n const business = parsed?.business || sess.business;\n const interest = parsed?.interest || sess.interest;\n if (name !== sess.name || business !== sess.business || interest !== sess.interest) {\n await setSession(wa, sess.step === \"new\" ? \"normal\" : sess.step, name, business, interest);\n }\n\n // Booking intent: collect what's missing, then confirm.\n if (parsed?.intent === \"book\") {\n const missing: string[] = [];\n if (!name) missing.push(\"name\");\n if (!business) missing.push(\"business\");\n if (missing.length) {\n const ask = missing.length === 2\n ? `Happy to set that up. Can I get your name and your business name?`\n : missing[0] === \"name\"\n ? `Happy to set that up. What's your name?`\n : `Nice - and what's the business called?`;\n await setSession(wa, \"collecting\", name, business, interest || \"both\");\n lastPath = \"collecting\";\n await addHistory(wa, \"assistant\", ask);\n await sendWhatsApp(wa, ask);\n return;\n }\n const intr = interest || \"both\";\n const intrLabel = intr === \"receptionist\" ? \"the WhatsApp AI receptionist\" : intr === \"visibility\" ? \"AI search visibility\" : \"both services\";\n const ask = confirmLeadAsk(name, business, intrLabel);\n await setSession(wa, \"confirm_lead\", name, business, intr);\n lastPath = \"confirm_lead\";\n await addHistory(wa, \"assistant\", ask);\n await sendWhatsApp(wa, ask);\n return;\n }\n\n // While collecting, a message that carries the missing info should move us forward.\n if (sess.step === \"collecting\" && name && business) {\n const intr = interest || \"both\";\n const intrLabel = intr === \"receptionist\" ? \"the WhatsApp AI receptionist\" : intr === \"visibility\" ? \"AI search visibility\" : \"both services\";\n const ask = confirmLeadAsk(name, business, intrLabel);\n await setSession(wa, \"confirm_lead\", name, business, intr);\n await addHistory(wa, \"assistant\", ask);\n await sendWhatsApp(wa, ask);\n return;\n }\n\n // Explicit human request.\n if (parsed?.intent === \"handoff\") {\n lastPath = \"handoff\";\n await alertOwner(`Human requested`, `WhatsApp: +${wa}\\nName: ${name || \"unknown\"}\\nBusiness: ${business || \"unknown\"}\\nLast message: \"${body.slice(0, 300)}\"`);\n await addHistory(wa, \"assistant\", HANDOFF_MSG);\n await sendWhatsApp(wa, HANDOFF_MSG);\n return;\n }\n\n // Greeting on a fresh conversation.\n if (parsed?.intent === \"greeting\" && sess.step === \"new\" && history.length === 0) {\n const reply = greetingMsg(name);\n lastPath = \"greeting\";\n await setSession(wa, \"normal\", name, business, interest);\n await addHistory(wa, \"assistant\", reply);\n await sendWhatsApp(wa, reply);\n return;\n }\n\n // Everything else: AI reply.\n let reply = await aiReply(body, history);\n if (!reply) reply = await aiReply(body, history); // one retry\n lastPath = reply ? \"ai\" : \"fallback\";\n if (!reply) {\n reply = greetingMsg(name); // AI unavailable: graceful, human-sounding fallback\n }\n if (reply.trim() === \"HANDOFF\" || reply.startsWith(\"HANDOFF\")) {\n lastPath = \"handoff_ai\";\n await alertOwner(`Question needs a human`, `WhatsApp: +${wa}\\nName: ${name || \"unknown\"}\\nBusiness: ${business || \"unknown\"}\\nQuestion: \"${body.slice(0, 300)}\"`);\n reply = HANDOFF_MSG;\n }\n if (sess.step === \"confirm_lead\") {\n reply = reply + \"\\n\\n\" + confirmNudge;\n }\n if (sess.step === \"new\") await setSession(wa, \"normal\", name, business, interest);\n await addHistory(wa, \"assistant\", reply);\n await sendWhatsApp(wa, reply);\n}\n\n// ---------------- HTTP entry ----------------\nexport default async function (req: Request): Promise {\n const url = new URL(req.url);\n\n // Meta webhook verification\n if (req.method === \"GET\") {\n const mode = url.searchParams.get(\"hub.mode\");\n const token = url.searchParams.get(\"hub.verify_token\");\n const challenge = url.searchParams.get(\"hub.challenge\");\n if (mode === \"subscribe\" && token === VERIFY_TOKEN && challenge) {\n return new Response(challenge, { status: 200 });\n }\n // debug/diagnostics\n if (url.searchParams.get(\"debug\") === \"heytrill2026\") {\n await ensureTables();\n const sessions = await sqlite.execute(`SELECT * FROM ht_sessions ORDER BY updated_at DESC LIMIT 50`);\n const leads = await sqlite.execute(`SELECT * FROM ht_leads ORDER BY ts DESC LIMIT 50`);\n const outbox = await sqlite.execute(`SELECT * FROM ht_outbox ORDER BY ts DESC LIMIT 100`);\n return Response.json({ sessions: sessions.rows, leads: leads.rows, outbox: outbox.rows, meta_configured: !!(META_TOKEN && PHONE_NUMBER_ID) });\n }\n return new Response(\"heytrill receptionist ok\");\n }\n\n if (req.method !== \"POST\") return new Response(\"ok\");\n\n // Test harness: {\"test\":true,\"from\":\"91...\",\"body\":\"...\"} -> runs the engine, replies recorded in outbox, returns JSON\n let payload: any;\n try {\n payload = await req.json();\n } catch (_e) {\n return new Response(\"bad json\", { status: 400 });\n }\n\n if (payload && payload.test === true) {\n const wa = String(payload.from || \"919999999999\");\n const body = String(payload.body || \"\");\n await ensureTables();\n const before = await sqlite.execute({ sql: `SELECT COUNT(*) FROM ht_outbox`, args: [] });\n const n0 = Number(before.rows?.[0]?.[0] || 0);\n await handleMessage(wa, body);\n const after = await sqlite.execute({ sql: `SELECT text FROM ht_outbox ORDER BY id`, args: [] });\n const texts = (after.rows || []).slice(n0).map((r) => String(r[0]));\n return Response.json({ replies: texts, path: lastPath });\n }\n\n // Meta Cloud API webhook\n try {\n for (const entry of payload?.entry ?? []) {\n for (const change of entry?.changes ?? []) {\n const value = change?.value;\n const messages = value?.messages;\n if (!Array.isArray(messages)) continue; // statuses etc: ignore\n for (const msg of messages) {\n const wa = String(msg?.from || \"\");\n const id = String(msg?.id || \"\");\n if (!wa || !id) continue;\n if (await alreadyProcessed(id)) continue;\n await markProcessed(id);\n if (msg?.type === \"text\" && msg?.text?.body) {\n await handleMessage(wa, String(msg.text.body));\n } else {\n const fallback = `Sorry, I can only read text messages for now - could you type that out?`;\n await sendWhatsApp(wa, fallback);\n }\n }\n }\n }\n } catch (err) {\n return new Response(\"error\", { status: 200 }); // always 200 so Meta doesn't retry-storm\n }\n return new Response(\"ok\", { status: 200 });\n}\n","createdAt",["D",1789033343388],"branchVersion","branchId","4d6f32cf-d725-4d74-8cf9-91088c8e84e4","id","3630226e-2970-4296-8bd2-a5a5c7d0739a","salonbot",["D",1788595835206],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","imageUrl","a7b0a2c2-1be4-4203-9fcd-83311077f65b","pinnedFileId","7cd6c472-a901-11f1-8513-1607ee4eb77e","pinPreview",true,"pinMigrated","screenshotVersion","likeCount",0,"orgId","01a0709c-b2b2-772d-ba3f-c6e0c645cf6d","tursoName","3630226e297042968bd2a5a5c7d0739a","tursoHostname","3630226e297042968bd2a5a5c7d0739a-val-town.aws-us-east-2.turso.io","tursoMeasuredAt",["D",1789476648181],"pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_99":98,"_106":101},"org",{"_99":98,"_100":101,"_102":101,"_18":54,"_103":104,"_105":25},"branch",{"_13":88,"_32":89,"_43":42,"_90":44,"_91":-5,"_92":-5,"_93":-5,"_94":-5,"_95":-5,"_96":45,"_97":98},"isOwned",56,"main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","deepthisudhakar023","handle","displayName","","avatar","tier","free","canRestrictVals","profileImageUrl","branchName","adoptOrgId",{"_43":44,"_32":45,"_38":188,"_47":-5,"_48":25,"_49":50,"_51":50,"_52":-5,"_53":-5,"_18":54,"_55":56,"_57":58,"_59":-5,"_60":-5,"_61":62,"_63":64,"_65":66,"_67":68,"_69":189,"_71":-5,"_72":73,"_74":73,"_75":76,"_77":76,"_78":76,"_79":73,"_80":73,"_81":190,"_83":191,"_85":192,"_87":25},"tree",[171,172,173,174],"files",[171,172,173,174],"counts",{"_160":62,"_161":153,"_162":62,"_163":164,"_165":166},"contents",[128,129,130,131],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},{"_43":157,"_32":28,"_30":31,"_135":-5,"_41":42,"_40":14,"_137":25,"_38":158,"_13":153,"_33":34,"_35":37,"_24":25,"_141":-5,"_27":159},{"_43":150,"_32":151,"_30":152,"_135":-5,"_41":42,"_40":153,"_137":58,"_38":154,"_13":62,"_33":20,"_35":155,"_24":25,"_141":-5,"_27":156},{"_43":143,"_32":144,"_30":56,"_135":-5,"_41":42,"_40":145,"_137":58,"_38":146,"_13":147,"_33":34,"_35":148,"_24":25,"_141":-5,"_27":149},{"_43":132,"_32":133,"_30":134,"_135":-5,"_41":42,"_40":136,"_137":58,"_38":138,"_13":62,"_33":139,"_35":140,"_24":25,"_141":-5,"_27":142},"155f3ddf-4bc5-4d5b-a078-1c9496d0bfbd","reminder-tick.ts","c2b586da-a91b-11f1-a505-1607ee4eb77e","parentId",11,"latest",["D",1788607212085],"interval","// Runs on Val Town's interval schedule and triggers the salonbot\n// reminder / post-visit follow-up tick on the HTTP val.\nexport default async function () {\n const res = await fetch(\n \"https://deepthisudhakar023--7cd6c472a90111f185131607ee4eb77e.web.val.run/?tick=salonbot2026\",\n );\n console.log(\"salonbot tick:\", res.status, await res.text());\n}\n","label",[133],"1be8ac98-565e-4c81-bc57-263bf9925555","new-file-6226.ts",31,["D",1788945003725],28,"// Glow & Grace Salon WhatsApp bot - v29: small talk gets a human answer + booking steer,\n// never the human-handoff. v28: plain human receptionist voice (no forced enthusiasm),\n// remembers recent chat context (rolling history feeds both AI layers) and customer names.\n// Still: understands Hindi, Kannada, Tamil, Telugu (roman + native script), always replies in English.\n// Natural-language first (Groq parse layer, intent-only, never writes state).\n// All state changes stay on deterministic rails: GG-XXXX bookings, owner emails.\n// Numbered picks still work silently, but nothing asks the customer for one.\nimport { sqlite } from \"https://esm.town/v/std/sqlite\";\nimport { email } from \"https://esm.town/v/std/email\";\n\nconst SERVICES: Record = {\n \"1\": { name: \"Haircut\", kn: \"ಹೇರ್‌ಕಟ್\", price: 800 },\n \"2\": { name: \"Hair Spa\", kn: \"ಹೇರ್ ಸ್ಪಾ\", price: 1500 },\n \"3\": { name: \"Facial\", kn: \"ಫೇಶಿಯಲ್\", price: 1200 },\n \"4\": { name: \"Manicure + Pedicure\", kn: \"ಮ್ಯಾನಿಕ್ಯೂರ್ + ಪೆಡಿಕ್ಯೂರ್\", price: 1000 },\n};\nconst SLOTS: Record = { \"1\": \"11:30 AM\", \"2\": \"2:00 PM\", \"3\": \"5:30 PM\" };\n// Minutes since midnight (IST) for each slot label - used by the reminder/follow-up tick.\nconst SLOT_MINUTES: Record = { \"11:30 AM\": 690, \"2:00 PM\": 840, \"5:30 PM\": 1050 };\nconst SLOT_LIST = [\"11:30 AM\", \"2:00 PM\", \"5:30 PM\"];\n// Customers can't book a slot less than this many minutes away.\nconst LEAD_MINUTES = 15;\n\n// Demo Google review link. A real client deployment uses the salon's own\n// review URL from their Google Business Profile.\nconst GOOGLE_REVIEW_URL = \"https://www.google.com/maps/search/Glow+%26+Grace+Salon+HSR+Layout+Bengaluru\";\n\n// Twilio sandbox sender. Sandbox can only message numbers that joined it.\nconst TWILIO_FROM = \"whatsapp:+14155238886\";\nconst META_VERIFY_TOKEN = \"salonbot2026meta\";\n// Meta WhatsApp Cloud API mode activates when META_TOKEN + META_PHONE_ID are set.\n// Free-form works inside the 24h customer window; outside it we fall back to\n// the pre-approved hello_world template on the test number.\n\n// Mid-flow sessions (picking service/slot, pending confirmation) expire after\n// 45 min idle so a customer who wanders off and returns later starts clean. A\n// completed booking never expires, so cancels work whenever they send it.\nconst IDLE_RESET_MS = 45 * 60 * 1000;\n\n// ---------- message templates (natural voice first, menu as fallback) ----------\n\n// pick() adds light variation so the bot never sounds like a recording.\nconst pick = (arr: T[]): T => arr[Math.floor(Math.random() * arr.length)];\n\nconst greetingMsg = (name?: string) => {\n const hi = name ? `Hi ${name}!` : pick([\"Hi!\", \"Hello!\", \"Hi there!\"]);\n return pick([\n `${hi} You've reached *Glow & Grace Salon*, HSR Layout. What can I do for you - haircut, hair spa, facial, or a mani-pedi?`,\n `${hi} *Glow & Grace Salon* here. Tell me what you'd like and when, and I'll set it up.`,\n `${hi} Thanks for messaging *Glow & Grace Salon*. What would you like to get done?`,\n ]);\n};\n\n// Full price list, only on explicit ask (\"menu\"/\"price\") or as the fallback\n// for messages we truly can't understand.\nconst WELCOME = `Here's our price list:\n\n- *Haircut* - ₹800\n- *Hair Spa* - ₹1,500\n- *Facial* - ₹1,200\n- *Mani + Pedi* - ₹1,000\n\nTell me which one you'd like and when, and I'll book it.`;\n\nconst SERVICE_ASKS = [\n `Sure - what would you like? We do haircuts, hair spa, facials, and mani-pedis.`,\n `Of course. What are you thinking - haircut, hair spa, facial, or mani-pedi?`,\n];\nconst serviceAskMsg = () => pick(SERVICE_ASKS);\n\nconst hairAsk = `For hair we do a *Haircut* (₹800) or a *Hair Spa* (₹1,500). Which would you like?`;\n\nfunction fmtSlots(slots: string[]): string {\n const w = slots.map((s) => `*${s}*`);\n if (w.length === 1) return w[0];\n return w.slice(0, -1).join(\", \") + \" or \" + w[w.length - 1];\n}\n\nconst slotAsk = (svcName: string, datePretty: string, slots: string[]) =>\n pick([\n `For *${svcName}* on ${datePretty}, I have ${fmtSlots(slots)} free. Which works for you?`,\n `${datePretty} I can do ${fmtSlots(slots)} for your *${svcName}*. Which one should I take?`,\n ]);\n\nconst slotPassedAsk = (svcName: string, slots: string[]) =>\n `That slot's just gone for today, sorry. I still have ${fmtSlots(slots)} for your *${svcName}* - shall I take one of those?`;\n\nconst wrappedTodayAsk = (svcName: string, tomorrowPretty: string) =>\n `Today's fully booked, I'm afraid. ${tomorrowPretty} I have ${fmtSlots(SLOT_LIST)} for your *${svcName}* - want one of those?`;\n\nconst confirmAsk = (svcName: string, price: number, slot: string, datePretty: string) =>\n `Just to confirm: *${svcName}* on *${datePretty}* at *${slot}* - ₹${price}, pay at the salon.\nShall I book it?`;\n\nconst confirmMoveAsk = (serviceName: string, id: string, slot: string, datePretty: string) =>\n `Move your *${serviceName}* (${id}) to *${slot}* on *${datePretty}* - is that right?`;\n\nconst rescheduleAskNatural = (serviceName: string, slot: string, datePretty: string) =>\n `Your *${serviceName}* is currently at *${slot}* on ${datePretty}. When would you like to move it to?`;\n\nconst cancelAskNatural = (serviceName: string, slot: string, datePretty: string, id: string) =>\n `Just to be sure - cancel your *${serviceName}* at *${slot}* on ${datePretty} (${id})?\nReply yes to cancel, no to keep it.`;\n\nconst pendingDropped = `No problem, dropped it. Anything else I can help with?`;\nconst confirmNudge = `Just reply yes to confirm, or no to drop it.`;\n\nconst noBookingFound = `I can't find an active booking on this number. If you'd like one, tell me the service and time.`;\n\nconst slotMenu = (s: { name: string; price: number }) =>\n `*${s.name}* - ₹${s.price}.\nWhat time works today? I have ${fmtSlots(SLOT_LIST)} - you can also just say morning, afternoon or evening.`;\n\nconst rescheduleMenu = (serviceName: string, id: string) =>\n `Sure, let's move your *${serviceName}* (${id}).\nWhen works better? Today I have ${fmtSlots(SLOT_LIST)}, or tell me another day.`;\n\nconst confirmation = (s: { name: string }, slot: string, dateStr: string, id: string, custName?: string) =>\n `Done${custName ? \", \" + custName : \"\"} - you're booked 🎉 *${s.name}*, ${slot} on ${dateStr}.\n\nBooking ID: *${id}*\nGlow & Grace Salon, 27th Main, HSR Layout\nPay at the salon, just show this message at the counter.\n\nI'll send a reminder before your slot. If you need to move or cancel, just message me.`;\n\nconst rescheduled = (serviceName: string, slot: string, dateStr: string, id: string) =>\n `Done, moved ✅ Your *${serviceName}* is now at *${slot}* on ${dateStr}.\nSame booking ID (*${id}*) - I'll remind you before the new slot.`;\n\nconst reminderMsg = (serviceName: string, slot: string, id: string) =>\n `⏰ Reminder: your *${serviceName}* at Glow & Grace Salon is today at *${slot}*.\n\nBooking ID: *${id}*\n27th Main, HSR Layout\nSee you then! If you need to move or cancel, just message me.`;\n\nconst followupMsg = (serviceName: string) =>\n `Hi! How was your *${serviceName}* at Glow & Grace today?\nCould you rate it from *1* to *5*? Just one number is fine.`;\n\nconst reviewNudge = `That's great to hear, thank you!\nIf you have 30 seconds, a Google review would really help us:\n${GOOGLE_REVIEW_URL}`;\n\nconst serviceRecovery = `Thank you for telling us, and I'm sorry the visit wasn't good.\nSomeone from our team will reach out shortly to make it right. 🙏`;\n\nconst HANDOFF = `That's a bit outside what I can answer, so someone from the salon will reply to you shortly.\nIn the meantime I can book you in - just tell me the service and time, or type *menu* for prices.`;\n\nconst CANCEL = (id: string) =>\n `Cancelled ✅ Booking ${id} is off.\nHope to see you another time.`;\n\n\nfunction twiml(msg: string): Response {\n const esc = msg.replace(/&/g, \"&\").replace(//g, \">\");\n return new Response(\n `${esc}`,\n { headers: { \"Content-Type\": \"text/xml\" } },\n );\n}\n\nfunction istNow(): { dateStr: string; mins: number; pretty: string } {\n const fmt = new Intl.DateTimeFormat(\"en-GB\", {\n timeZone: \"Asia/Kolkata\", year: \"numeric\", month: \"2-digit\", day: \"2-digit\",\n hour: \"2-digit\", minute: \"2-digit\", hour12: false,\n });\n const p = fmt.formatToParts(new Date());\n const g = (t: string) => p.find((x) => x.type === t)?.value || \"0\";\n const h = parseInt(g(\"hour\")) % 24;\n return {\n dateStr: `${g(\"year\")}-${g(\"month\")}-${g(\"day\")}`,\n mins: h * 60 + parseInt(g(\"minute\")),\n pretty: new Intl.DateTimeFormat(\"en-IN\", {\n weekday: \"long\", day: \"numeric\", month: \"long\", timeZone: \"Asia/Kolkata\",\n }).format(new Date()),\n };\n}\n\n// ---------- deterministic date/slot helpers (no AI involved in these) ----------\n\nfunction isoAddDays(iso: string, n: number): string {\n const [y, m, d] = iso.split(\"-\").map(Number);\n return new Date(Date.UTC(y, m - 1, d + n)).toISOString().slice(0, 10);\n}\nfunction prettyDate(iso: string, fallback = \"\"): string {\n if (!/^\\d{4}-\\d{2}-\\d{2}$/.test(iso || \"\")) return fallback;\n const [y, m, d] = iso.split(\"-\").map(Number);\n return new Intl.DateTimeFormat(\"en-IN\", {\n weekday: \"long\", day: \"numeric\", month: \"long\", timeZone: \"UTC\",\n }).format(new Date(Date.UTC(y, m - 1, d)));\n}\n// Resolve the parser's date token to an ISO date. null = not mentioned.\n// Past dates clamp to today; anything beyond 7 days out is rejected (null).\nfunction resolveDateISO(d: string | null, today: string): string | null {\n if (!d) return null;\n if (d === \"today\") return today;\n if (d === \"tomorrow\") return isoAddDays(today, 1);\n if (d === \"weekend\") {\n const [y, m, dd] = today.split(\"-\").map(Number);\n const dow = new Date(Date.UTC(y, m - 1, dd)).getUTCDay(); // 0 Sun .. 6 Sat\n return isoAddDays(today, (6 - dow + 7) % 7); // next Saturday (today if Saturday)\n }\n if (/^\\d{4}-\\d{2}-\\d{2}$/.test(d)) {\n if (d < today) return today;\n if (d > isoAddDays(today, 7)) return null;\n return d;\n }\n return null;\n}\nfunction resolveSlotLabel(t: string | null): string | null {\n if (!t) return null;\n const map: Record = {\n morning: \"11:30 AM\", afternoon: \"2:00 PM\", evening: \"5:30 PM\",\n \"11:30\": \"11:30 AM\", \"14:00\": \"2:00 PM\", \"17:30\": \"5:30 PM\",\n \"11:30 AM\": \"11:30 AM\", \"2:00 PM\": \"2:00 PM\", \"5:30 PM\": \"5:30 PM\",\n };\n return map[t] || null;\n}\nfunction slotsForDate(dateISO: string, now: { dateStr: string; mins: number }): string[] {\n if (dateISO !== now.dateStr) return SLOT_LIST.slice();\n return SLOT_LIST.filter((s) => SLOT_MINUTES[s] > now.mins + LEAD_MINUTES);\n}\nfunction slotStillOpen(slot: string, dateISO: string, now: { dateStr: string; mins: number }): boolean {\n return dateISO !== now.dateStr || SLOT_MINUTES[slot] > now.mins + LEAD_MINUTES;\n}\n\nconst YES_RE = /^(y|yea|yeah|yep|yup|yes|sure|ok|okay|okk|confirm|confirmed|done|book it|lock it|haan|ha|han|ಹೌದು|ಸರಿ|ಓಕೆ|houdu|sari|seri|हाँ|ஆம்|சரி|aam|avunu|అవుನು|సరೆ|sare)\\b/;\nconst NO_RE = /^(n|no|nope|nah|not now|no thanks|ಬೇಡ|ಬೇಡಾ|ಇಲ್ಲ|beda|illa|illai|nahi|नहीं|வேண்டாம்|வேணா|venda|వద్దు|vaddu|లేదు|ledu|wait)\\b/;\n\nlet tableReady = false;\nasync function ensureTable() {\n if (tableReady) return;\n await sqlite.execute(\n `CREATE TABLE IF NOT EXISTS sessions (from_num TEXT PRIMARY KEY, step TEXT, service TEXT, updated_at INTEGER)`,\n );\n await sqlite.execute(\n `CREATE TABLE IF NOT EXISTS bookings (id TEXT, from_num TEXT, service TEXT, slot TEXT, status TEXT, created_at INTEGER)`,\n );\n await sqlite.execute(\n `CREATE TABLE IF NOT EXISTS chat_log (from_num TEXT, role TEXT, text TEXT, ts INTEGER)`,\n );\n await sqlite.execute(\n `CREATE TABLE IF NOT EXISTS names (from_num TEXT PRIMARY KEY, name TEXT)`,\n );\n // Migrations for v2 features (reschedule context, reminder/follow-up state).\n const migrations = [\n `ALTER TABLE sessions ADD COLUMN context TEXT DEFAULT ''`,\n `ALTER TABLE bookings ADD COLUMN date TEXT DEFAULT ''`,\n `ALTER TABLE bookings ADD COLUMN reminder_sent INTEGER DEFAULT 0`,\n `ALTER TABLE bookings ADD COLUMN followup_sent INTEGER DEFAULT 0`,\n `ALTER TABLE bookings ADD COLUMN rating INTEGER`,\n ];\n for (const m of migrations) {\n try { await sqlite.execute(m); } catch (_e) { /* column already exists */ }\n }\n tableReady = true;\n}\nasync function getSession(from: string) {\n await ensureTable();\n const r = await sqlite.execute({\n sql: `SELECT step, service, updated_at, context FROM sessions WHERE from_num = ?`,\n args: [from],\n });\n if (r.rows && r.rows.length) {\n const step = String(r.rows[0][0]);\n const service = String(r.rows[0][1] || \"\");\n const updated = Number(r.rows[0][2] || 0);\n const context = String(r.rows[0][3] || \"\");\n if ([\"await_service\", \"await_slot\", \"await_reschedule\", \"await_confirm\"].includes(step) && Date.now() - updated > IDLE_RESET_MS) {\n return { step: \"new\", service: \"\", context: \"\" };\n }\n return { step, service, context };\n }\n return { step: \"new\", service: \"\", context: \"\" };\n}\nasync function setSession(from: string, step: string, service: string, context = \"\") {\n await ensureTable();\n await sqlite.execute({\n sql: `INSERT INTO sessions (from_num, step, service, context, updated_at) VALUES (?, ?, ?, ?, ?)\n ON CONFLICT(from_num) DO UPDATE SET step=excluded.step, service=excluded.service, context=excluded.context, updated_at=excluded.updated_at`,\n args: [from, step, service, context, Date.now()],\n });\n}\nasync function logMsg(from: string, role: string, text: string) {\n await ensureTable();\n await sqlite.execute({ sql: `INSERT INTO chat_log (from_num, role, text, ts) VALUES (?, ?, ?, ?)`, args: [from, role, text.slice(0, 500), Date.now()] });\n // Keep only the 20 most recent messages per number.\n await sqlite.execute({\n sql: `DELETE FROM chat_log WHERE from_num = ? AND ts NOT IN (SELECT ts FROM chat_log WHERE from_num = ? ORDER BY ts DESC LIMIT 20)`,\n args: [from, from],\n });\n}\nasync function getHistory(from: string): Promise<{ role: string; text: string }[]> {\n await ensureTable();\n const r = await sqlite.execute({\n sql: `SELECT role, text FROM chat_log WHERE from_num = ? ORDER BY ts DESC LIMIT 8`,\n args: [from],\n });\n return (r.rows || []).map((row) => ({ role: String(row[0]), text: String(row[1]) })).reverse();\n}\nasync function getName(from: string): Promise {\n await ensureTable();\n const r = await sqlite.execute({ sql: `SELECT name FROM names WHERE from_num = ?`, args: [from] });\n return r.rows && r.rows.length ? String(r.rows[0][0] || \"\") : \"\";\n}\nasync function setName(from: string, name: string) {\n await ensureTable();\n await sqlite.execute({\n sql: `INSERT INTO names (from_num, name) VALUES (?, ?) ON CONFLICT(from_num) DO UPDATE SET name=excluded.name`,\n args: [from, name],\n });\n}\nasync function saveBooking(id: string, from: string, service: string, slot: string, dateStr: string) {\n await ensureTable();\n await sqlite.execute({\n sql: `INSERT INTO bookings (id, from_num, service, slot, status, created_at, date, reminder_sent, followup_sent) VALUES (?, ?, ?, ?, 'booked', ?, ?, 0, 0)`,\n args: [id, from, service, slot, Date.now(), dateStr],\n });\n}\nasync function latestBooking(from: string): Promise<{ id: string; service: string; slot: string; date: string } | null> {\n await ensureTable();\n const r = await sqlite.execute({\n sql: `SELECT id, service, slot, date FROM bookings WHERE from_num = ? AND status = 'booked' ORDER BY created_at DESC LIMIT 1`,\n args: [from],\n });\n if (!r.rows || !r.rows.length) return null;\n return { id: String(r.rows[0][0]), service: String(r.rows[0][1]), slot: String(r.rows[0][2]), date: String(r.rows[0][3] || \"\") };\n}\nasync function cancelLatestBooking(from: string): Promise<{ id: string; service: string; slot: string } | null> {\n const row = await latestBooking(from);\n if (!row) return null;\n await sqlite.execute({ sql: `UPDATE bookings SET status = 'cancelled' WHERE id = ?`, args: [row.id] });\n return row;\n}\nasync function cancelBookingById(id: string) {\n await ensureTable();\n await sqlite.execute({ sql: `UPDATE bookings SET status = 'cancelled' WHERE id = ? AND status = 'booked'`, args: [id] });\n}\nasync function rescheduleBooking(id: string, newSlot: string, newDate: string) {\n await ensureTable();\n // Reset reminder/follow-up flags so the customer gets nudges for the NEW time.\n await sqlite.execute({\n sql: `UPDATE bookings SET slot = ?, date = COALESCE(NULLIF(?, ''), date), reminder_sent = 0, followup_sent = 0 WHERE id = ? AND status = 'booked'`,\n args: [newSlot, newDate || \"\", id],\n });\n}\n\n// Proactive WhatsApp send through the Twilio sandbox. Only possible once\n// TWILIO_ACCOUNT_SID / TWILIO_AUTH_TOKEN are set on this val. Sandbox delivers\n// only to numbers that sent the join code.\nasync function sendWhatsApp(toNum: string, body: string, tplVars?: Record, forceTemplate = false): Promise<{ ok: boolean; detail: string }> {\n const metaTok = Deno.env.get(\"META_TOKEN\");\n const metaPid = Deno.env.get(\"META_PHONE_ID\");\n if (metaTok && metaPid) {\n const digits = toNum.replace(/\\D/g, \"\");\n const metaPost = async (payload: unknown): Promise<{ ok: boolean; detail: string }> => {\n try {\n const res = await fetch(`https://graph.facebook.com/v21.0/${metaPid}/messages`, {\n method: \"POST\",\n headers: { \"Authorization\": `Bearer ${metaTok}`, \"Content-Type\": \"application/json\" },\n body: JSON.stringify(payload),\n });\n const txt = await res.text();\n if (!res.ok) return { ok: false, detail: `meta ${res.status}: ${txt.slice(0, 250)}` };\n let mid = \"\";\n try { mid = String(JSON.parse(txt)?.messages?.[0]?.id || \"\"); } catch (_e) { /* ignore */ }\n return { ok: true, detail: `sent ${mid}` };\n } catch (e) {\n return { ok: false, detail: `fetch error: ${String(e).slice(0, 150)}` };\n }\n };\n const tpl = { messaging_product: \"whatsapp\", to: digits, type: \"template\", template: { name: \"hello_world\", language: { code: \"en_US\" } } };\n if (forceTemplate) return await metaPost(tpl);\n const t = await metaPost({ messaging_product: \"whatsapp\", recipient_type: \"individual\", to: digits, type: \"text\", text: { preview_url: true, body } });\n if (!t.ok && /1310|1320|131047|131026/.test(t.detail)) return await metaPost(tpl);\n return t;\n }\n const sid = Deno.env.get(\"TWILIO_ACCOUNT_SID\");\n const tok = Deno.env.get(\"TWILIO_AUTH_TOKEN\");\n if (!sid || !tok) return { ok: false, detail: \"twilio env vars missing\" };\n const to = toNum.startsWith(\"whatsapp:\") ? toNum : `whatsapp:${toNum}`;\n // New Twilio trial accounts require a Twilio-provided template (ContentSid)\n // for business-initiated messages. Trial template: Appointment Reminders\n // \"Your appointment is coming up on {{1}} at {{2}}...\" (1=date, 2=time).\n // Free-form is only allowed inside a customer-initiated 24h window; if a\n // free-form attempt is rejected with 21654, retry as the template.\n const contentSid = Deno.env.get(\"TWILIO_CONTENT_SID\");\n const attempt = async (params: Record): Promise<{ ok: boolean; detail: string }> => {\n try {\n const res = await fetch(`https://api.twilio.com/2010-04-01/Accounts/${sid}/Messages.json`, {\n method: \"POST\",\n headers: {\n \"Authorization\": \"Basic \" + btoa(`${sid}:${tok}`),\n \"Content-Type\": \"application/x-www-form-urlencoded\",\n },\n body: new URLSearchParams(params).toString(),\n });\n const txt = await res.text();\n if (!res.ok) return { ok: false, detail: `twilio ${res.status}: ${txt.slice(0, 250)}` };\n let msid = \"\";\n try { msid = String(JSON.parse(txt).sid || \"\"); } catch (_e) { /* ignore */ }\n return { ok: true, detail: `sent ${msid}` };\n } catch (e) {\n return { ok: false, detail: `fetch error: ${String(e).slice(0, 150)}` };\n }\n };\n if (contentSid && (forceTemplate || tplVars)) {\n return await attempt({ To: to, From: TWILIO_FROM, ContentSid: contentSid, ContentVariables: JSON.stringify(tplVars || { \"1\": body }) });\n }\n const r = await attempt({ To: to, From: TWILIO_FROM, Body: body });\n if (!r.ok && r.detail.includes(\"21654\") && contentSid) {\n return await attempt({ To: to, From: TWILIO_FROM, ContentSid: contentSid, ContentVariables: JSON.stringify(tplVars || { \"1\": body }) });\n }\n return r;\n}\n\n// Scheduled tick (called by the interval val + manually via ?tick=). Sends due\n// reminders a few hours before the slot and post-visit feedback requests ~1h\n// after it. Idempotent via reminder_sent / followup_sent flags.\nasync function runTick(): Promise[]> {\n await ensureTable();\n const now = istNow();\n const r = await sqlite.execute({\n sql: `SELECT id, from_num, service, slot, reminder_sent, followup_sent FROM bookings WHERE status = 'booked' AND date = ?`,\n args: [now.dateStr],\n });\n const out: Record[] = [];\n for (const row of r.rows || []) {\n const [id, fromNum, service, slot] = [String(row[0]), String(row[1]), String(row[2]), String(row[3])];\n const remSent = Number(row[4] || 0);\n const fupSent = Number(row[5] || 0);\n const slotMins = SLOT_MINUTES[slot];\n if (slotMins === undefined) continue;\n const diff = slotMins - now.mins; // minutes until the slot (negative = past)\n if (!remSent && diff <= 150 && diff > -300) {\n const s = await sendWhatsApp(fromNum, reminderMsg(service, slot, id), { \"1\": now.pretty, \"2\": slot }, true);\n if (s.ok) await sqlite.execute({ sql: `UPDATE bookings SET reminder_sent = 1 WHERE id = ?`, args: [id] });\n out.push({ id, action: \"reminder\", ...s });\n }\n if (!fupSent && -diff >= 30 && -diff <= 720) {\n const s = await sendWhatsApp(fromNum, followupMsg(service), { \"1\": now.pretty, \"2\": slot });\n if (s.ok) {\n await sqlite.execute({ sql: `UPDATE bookings SET followup_sent = 1 WHERE id = ?`, args: [id] });\n await setSession(fromNum, \"feedback\", service, id);\n }\n out.push({ id, action: \"followup\", ...s });\n }\n }\n return out;\n}\n\n// ---------- AI layer #1: Q&A phrasing (answers questions, never touches state) ----------\n\nconst AI_SYSTEM = `You are the receptionist at Glow & Grace Salon, HSR Layout, Bengaluru, texting with customers on WhatsApp. You sound like a real person at the front desk - warm, relaxed, plain-spoken. Answer ONLY from this real salon data:\n- Services and prices: Haircut Rs.800, Hair Spa Rs.1500, Facial Rs.1200, Manicure + Pedicure Rs.1000\n- Slots every day: 11:30 AM, 2:00 PM, 5:30 PM. Bookings can be made up to 7 days ahead.\n- Hours: 10 AM to 7 PM. Address: Glow & Grace Salon, 27th Main, HSR Layout.\n- Payment at the salon. Customers book by simply saying the service and time in their own words (like \"haircut tomorrow evening\") - the bot confirms before anything is booked. The salon sends a reminder before the appointment and asks for a rating after the visit.\n\nSTRICT RULES:\n1. Never invent a price, service, slot, discount, timing, or policy. If the answer is not in the data above, reply with exactly one word: HANDOFF\n2. Questions about booking, prices, timings, slots, location, hours, payment, reminders, or rescheduling ARE answerable from the data - answer them, do not hand off.\n3. ALWAYS reply in English, whatever language the customer writes in.\n4. Write like a real person texting: short, varied sentences, contractions fine. NEVER use stock enthusiasm or AI cliches: no \"Ooh\", \"Great choice\", \"Love it\", \"Certainly\", \"I'd be happy to\", \"Absolutely!\", \"Happy to help\". Warmth comes from being direct and helpful, not from cheerleading. Don't end every message with a question or an exclamation.\n5. Emojis: most messages have none. At most one, only where it truly fits.\n6. Use the chat history. If the customer refers to something from earlier (\"that one\", \"the facial\", \"and haircut?\"), answer with that context instead of asking again. If you know their name, use it once in a while, not in every message.\n7. If the customer wants to book, tell them they can just say what they want and when - no menus or numbers needed.\n8. Anything not covered by the data (other services like bridal/makeup, product brands, hair advice, complaints, staff questions) is exactly: HANDOFF - but small talk and pleasantries (\"how are you\", \"thanks\", \"ok\", \"nice\", compliments, \"bye\") are NOT handoffs: answer them briefly like a real person would, then steer back to booking.\n9. NEVER confirm, modify, reschedule, or cancel a booking yourself. Booking changes happen only through the bot's own confirmation step.`;\n\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 try {\n const ctrl = new AbortController();\n const timer = setTimeout(() => ctrl.abort(), 8000);\n const res = await fetch(\"https://api.groq.com/openai/v1/chat/completions\", {\n method: \"POST\",\n headers: {\n \"Authorization\": `Bearer ${key}`,\n \"Content-Type\": \"application/json\",\n \"User-Agent\": \"Mozilla/5.0 (X11; Linux x86_64) AppleWebKit/537.36 Chrome/120 Safari/537.36\",\n },\n body: JSON.stringify({\n model: \"openai/gpt-oss-120b\",\n reasoning_effort: \"low\",\n temperature: 0.3,\n max_completion_tokens: 400,\n messages: [\n { role: \"system\", content: AI_SYSTEM },\n ...history.map((h) => ({ role: h.role === \"user\" ? \"user\" : \"assistant\", content: h.text })),\n { role: \"user\", content: userText },\n ],\n }),\n signal: ctrl.signal,\n });\n clearTimeout(timer);\n if (!res.ok) return null;\n const j = await res.json();\n let txt = String(j?.choices?.[0]?.message?.content || \"\").trim();\n txt = txt.replace(/\\*\\*/g, \"*\"); // WhatsApp bold uses single asterisks\n return txt || null;\n } catch (_e) {\n return null;\n }\n}\n\n// ---------- AI layer #2: intent parser. READ-ONLY: it classifies a message,\n// deterministic code below validates and executes every state change. ----------\n\ninterface ParsedMsg {\n intent: \"book\" | \"reschedule\" | \"cancel\" | \"query\" | \"greeting\" | \"smalltalk\" | \"other\";\n service: string | null; // haircut | hair_spa | facial | mani_pedi | hair_unspecified\n time: string | null; // morning | afternoon | evening | 11:30 | 14:00 | 17:30\n date: string | null; // today | tomorrow | weekend | YYYY-MM-DD\n name?: string | null; // customer's first name, if they introduced themselves\n}\n\nconst VALID_INTENTS = [\"book\", \"reschedule\", \"cancel\", \"query\", \"greeting\", \"smalltalk\", \"other\"];\nconst VALID_SERVICES = [\"haircut\", \"hair_spa\", \"facial\", \"mani_pedi\", \"hair_unspecified\"];\n\nasync function parseMessage(userText: string, now: { dateStr: string; pretty: string }, history: { role: string; text: string }[] = []): Promise {\n const key = Deno.env.get(\"GROQ_API_KEY\");\n if (!key) return null;\n const system = `You are the intent parser for a WhatsApp salon booking bot (Glow & Grace Salon, Bengaluru). Today is ${now.pretty} (${now.dateStr}), timezone IST.\n\nExtract booking intent from the customer's message. The customer may write in English, Hindi, Kannada, Tamil, or Telugu - in native script OR romanized (Latin) script - or any mix of these. Understand all of them. Handy vocabulary: chahiye (Hindi) / beku (Kannada) / venum (Tamil) / kavali (Telugu) = want; kal (Hindi) / nale (Kannada) / naalai (Tamil) / repu (Telugu) = tomorrow; aaj / ivattu / indru / ee roju = today; subah / beligge / kaalai / udayam = morning; dopahar / madhyahna / madhiyam / madhyahnam = afternoon; shaam / sanje / maalai / saayantram = evening. Reply with ONLY a JSON object, no markdown, no explanation:\n{\"intent\":\"book|reschedule|cancel|query|greeting|smalltalk|other\",\"service\":\"haircut|hair_spa|facial|mani_pedi|hair_unspecified|null\",\"time\":\"morning|afternoon|evening|11:30|14:00|17:30|null\",\"date\":\"today|tomorrow|weekend|YYYY-MM-DD|null\",\"name\":\"first name|null\"}\n\nRules:\n- intent: book = wants a new appointment. reschedule = move/change an EXISTING booking. cancel = cancel an existing booking. query = asks a question (price, hours, location, policies, what services you offer). greeting = ONLY hi/hello/namaste with no request. smalltalk = social chit-chat with no request: \"how are you\", \"thanks\", \"ok\", \"lol\", compliments (\"you're sweet\"), goodbyes, \"busy day?\", \"what's up\". other = anything else.\n- service: haircut, hair_spa (hair spa or hair treatment), facial, mani_pedi (manicure, pedicure, nails). If they want something for hair without specifics (\"something for my hair\"), use hair_unspecified.\n- time: use the band (morning/afternoon/evening) when the customer gives a band (\"evening\", \"after lunch\", \"morning\"). Use \"11:30\", \"14:00\" or \"17:30\" only for specific times - map to the nearest of these three.\n- date: resolve relative words using today above. \"this weekend\" or \"weekend\" = weekend. A specific day (\"Sunday\", \"on the 7th\") = its YYYY-MM-DD.\n- name: the customer's first name, ONLY if they introduce themselves in this message (\"I'm Ravi\", \"mera naam Priya\", \"naanu Asha\", \"en peru Divya\"). Otherwise null.\n- If recent chat context is provided with the message, use it to resolve references like \"that one\", \"the facial\", \"yes\" - but extract the intent of the NEW message only.\n- Only extract what the message actually says. Use null when absent.`;\n try {\n const ctrl = new AbortController();\n const timer = setTimeout(() => ctrl.abort(), 8000);\n const res = await fetch(\"https://api.groq.com/openai/v1/chat/completions\", {\n method: \"POST\",\n headers: {\n \"Authorization\": `Bearer ${key}`,\n \"Content-Type\": \"application/json\",\n \"User-Agent\": \"Mozilla/5.0 (X11; Linux x86_64) AppleWebKit/537.36 Chrome/120 Safari/537.36\",\n },\n body: JSON.stringify({\n model: \"openai/gpt-oss-120b\",\n reasoning_effort: \"low\",\n temperature: 0,\n max_completion_tokens: 150,\n messages: [\n { role: \"system\", content: system },\n { role: \"user\", content: history.length ? \"Recent chat:\\n\" + history.map((h) => (h.role === \"user\" ? \"Customer\" : \"Bot\") + \": \" + h.text).join(\"\\n\") + \"\\n\\nCustomer's new message: \" + userText : userText },\n ],\n }),\n signal: ctrl.signal,\n });\n clearTimeout(timer);\n if (!res.ok) return null;\n const j = await res.json();\n const txt = String(j?.choices?.[0]?.message?.content || \"\");\n const m = txt.match(/\\{[\\s\\S]*\\}/);\n if (!m) return null;\n const p = JSON.parse(m[0]);\n const intent = VALID_INTENTS.includes(p.intent) ? p.intent : \"other\";\n const service = VALID_SERVICES.includes(p.service) ? p.service : null;\n const time = typeof p.time === \"string\" && resolveSlotLabel(p.time) ? p.time : null;\n let date: string | null = null;\n if ([\"today\", \"tomorrow\", \"weekend\"].includes(p.date)) date = p.date;\n else if (typeof p.date === \"string\" && /^\\d{4}-\\d{2}-\\d{2}$/.test(p.date)) date = p.date;\n const name = typeof p.name === \"string\" && /^[A-Za-z][A-Za-z.' -]{1,29}$/.test(p.name.trim()) ? p.name.trim() : null;\n return { intent, service, time, date, name } as ParsedMsg;\n } catch (_e) {\n return null;\n }\n}\n\nfunction mapParsedService(s: string | null): string | null {\n if (!s) return null;\n const m: Record = { haircut: \"1\", hair_spa: \"2\", facial: \"3\", mani_pedi: \"4\", hair_unspecified: \"hair_any\" };\n return m[s] || null;\n}\n\n// Deterministic regex fallback so basic natural language still works if Groq\n// is down or times out.\nfunction regexParse(b: string): ParsedMsg | null {\n let service: string | null = null;\n if (/hair\\s*cut|haircut|ಹೇರ್‌?ಕಟ್|हेयर\\s*कट|ஹேர்‌?கட்|ஹேர் கட்|హెయిర್ కట್/.test(b)) service = \"haircut\";\n else if (/hair\\s*spa|ಹೇರ್ ಸ್ಪಾ|हेयर स्पा|ஹேர் ஸ்பா|హెయిర್ స్పಾ/.test(b)) service = \"hair_spa\";\n else if (/facial|ಫೇಶಿಯಲ್|फेशियल|फेशल|ஃபேஷியல்|௫ேஷியல்|ఫేషియల్/.test(b)) service = \"facial\";\n else if (/mani|pedi|ಮ್ಯಾನಿಕ್ಯೂರ್|ಪೆಡಿಕ್ಯೂರ್|मैनीक्यूर|पेडीक्यूर|மேனிக்கியூர்|பெடிக்கியூர்|మానిక్యూర్|పెడిక్యూర్/.test(b)) service = \"mani_pedi\";\n else if (/\\bhair\\b|ಕೂದಲು|கூந்தல்|జుట్టు/.test(b)) service = \"hair_unspecified\";\n let time: string | null = null;\n if (/morning|ಬೆಳಿಗ್ಗೆ|beligge|सुबह|subah|காலை|kaalai|kalai|ఉదయం|udayam/.test(b)) time = \"morning\";\n else if (/afternoon|ಮಧ್ಯಾಹ್ನ|दोपहर|dopahar|மதியம்|madhiyam|matthiyam|మధ్యాహ్నం|madhyahnam/.test(b)) time = \"afternoon\";\n else if (/evening|tonight|ಸಂಜೆ|sanje|शाम|shaam|sham|மாலை|maalai|సాయంత్రం|saayantram|sayantram/.test(b)) time = \"evening\";\n else if (/11[:. ]?30/.test(b)) time = \"11:30\";\n else if (/\\b(2|14)[:. ]?00|\\b2\\s?pm\\b/.test(b)) time = \"14:00\";\n else if (/5[:. ]?30|\\b5[:.]\\d2\\s?pm\\b/.test(b)) time = \"17:30\";\n let date: string | null = null;\n if (/tomorrow|ನಾಳೆ|nale|\\bkal\\b|कल|நாளை|naalai|nalai|రేపు|repu/.test(b)) date = \"tomorrow\";\n else if (/weekend|ವಾರಾಂತ್ಯ/.test(b)) date = \"weekend\";\n else if (/today|tonight|ಇವತ್ತು|ಇಂದು|ivattu|आज|aaj|இன்று|indru|inru|ఈరోజు|ee ?roju|iroju/.test(b)) date = \"today\";\n if (/cancel|ರದ್ದು|\\bradd\\b|रद्द|రద్దు|ரத்து/.test(b)) return { intent: \"cancel\", service: null, time: null, date: null };\n if (/reschedule|move|shift|postpone|change my|ಬದಲಾಯಿಸಿ|badal|बदल|மாற்று|maatru|మార్చు|marchu/.test(b)) return { intent: \"reschedule\", service, time, date };\n if (service || time || /book|appointment|slot|ಬುಕ್|ಅಪಾಯಿಂಟ|बुक|अपॉइंटमेंट|புக்|அப்பாயின்ட்மென்ட்|బుక్|అపాయింట్మెంట్|chahiye|चाहिए|\\bbeku\\b|ಬೇಕು|\\bvenum\\b|வேணும்|\\bkavali\\b|కావాలి/.test(b)) return { intent: \"book\", service, time, date };\n return null;\n}\n\nasync function notifyOwner(subject: string, text: string) {\n try {\n await email({ subject, text });\n } catch (_e) { /* best effort */ }\n}\n\n\n// ---------- Small talk: pleasantries get a human answer, never a handoff ----------\nfunction normalizeTalk(b: string): string {\n return b\n .replace(/[\\p{Extended_Pictographic}\\p{Emoji_Component}]/gu, \" \")\n .replace(/[.!?,~'\"\\-_:;()]+/g, \" \")\n .replace(/\\s+/g, \" \")\n .trim();\n}\nconst HOWRU_RE = /^(how (are|r) (you|u)|hru|how(s| is) it going|how(s| is) (your|the) day|busy day|wh?at(s| is) up|wass?up|sup|how do you do|kaise ho|kya haal( hai)?|hegiddi(ya|ra|ri)|chennagiddi(ya|ra)|epdi iruk(a|eenga)|nalla iruk(a|eenga)|ela unna?ru|bagunnar(a|u)|bagunnava)$/;\nconst THANKS_RE = /^(lol |haha |hehe |aww? |oh )?(thank(s| ?you| ?u)|thx|tq|ty|nandri|dhanya ?vad(a|s|alu)?|shukriy?a|\\u0CA7\\u0CA8\\u0CCD\\u0CAF\\u0CB5\\u0CBE\\u0CA6(\\u0C97\\u0CB3\\u0CC1)?|\\u0BA8\\u0BA9\\u0BCD\\u0BB1\\u0BBF|\\u0927\\u0928\\u094D\\u092F\\u0935\\u093E\\u0926|\\u0936\\u0941\\u0915\\u094D\\u0930\\u093F\\u092F\\u093E|\\u0C27\\u0C28\\u0C4D\\u0C2F\\u0C35\\u0C3E\\u0C26\\u0C3E\\u0C32\\u0C41)(( (so|very) much)|( a lot))?$/;\nconst ACK_RE = /^(ok+|okay+|okk+|k+|kk+|got it|gotcha|cool+|nice+|nice one|great+|awesome|amazing|perfect|superb?|good|good one|fine|alright|all good|sounds (good|great)|wow+|lol+|haha+|hehe+|noted|makes sense|fair enough|sure thing|sweet|you(r|re| are)( so| really)? (sweet|nice|kind|cute|smart|funny)|that(s| is| was)( so| really)? (sweet|nice|kind|lovely)|love (it|this|that)|lovely|wonderful|fantastic|brilliant|impressive|well done|good (bot|job)|nice (bot|one)|sari|seri|accha+|acha+|theek hai|thik hai|badiya)$/;\nconst GREET2_RE = /^good (morning|afternoon|evening)( (to )?you)?$/;\nconst FAREWELL_RE = /^(bye+|bye bye|see (you|ya)( later)?|gtg|talk( to you)? later|catch you later|good ?night|tata|poitu vare?n|baruthe?ne)$/;\nfunction hasBookingSignal(b: string): boolean {\n return /hair|spa|facial|mani|pedi|nail|\\bcut\\b|trim|book|appoint|slot|cancel|reschedule|postpone|\\bmove\\b|shift|tomorrow|today|tonight|weekend|\\d{1,2}[:.]\\d{2}|beku|venum|kavali|chahiye|nale|repu|naalai|radd|badal/.test(b);\n}\nfunction isSmalltalk(b: string): boolean {\n const t = normalizeTalk(b);\n if (!t) return /[\\p{Extended_Pictographic}]/u.test(b); // emoji-only message\n if (hasBookingSignal(b)) return false;\n return HOWRU_RE.test(t) || THANKS_RE.test(t) || ACK_RE.test(t) || GREET2_RE.test(t) || FAREWELL_RE.test(t);\n}\nfunction hashPick(s: string, arr: string[]): string {\n let h = 0;\n for (let i = 0; i < s.length; i++) h = (h * 31 + s.charCodeAt(i)) >>> 0;\n return arr[h % arr.length];\n}\nfunction cannedSmalltalk(b: string, name: string): string {\n const t = normalizeTalk(b);\n const n = name ? \", \" + name : \"\";\n if (HOWRU_RE.test(t)) return hashPick(b, [`Doing well, thanks for asking${n}!`, `Good, thanks for asking${n}!`]);\n if (THANKS_RE.test(t)) return hashPick(b, [\"Anytime!\", \"You're welcome!\", \"No trouble at all!\"]);\n if (GREET2_RE.test(t)) {\n const w = t.match(/morning|afternoon|evening/)?.[0] || \"day\";\n return `Good ${w}${n}!`;\n }\n if (FAREWELL_RE.test(t)) return hashPick(b, [\"Take care! Ping me whenever you want to book.\", \"Bye for now - message me anytime you need a slot.\"]);\n if (!t) return \"\\u{1F642}\"; // emoji-only message, smile back\n return hashPick(b, [\"Glad to hear it!\", \"That's kind of you to say!\", \"Okay!\"]);\n}\n\nexport default async function (req: Request): Promise {\n if (req.method !== \"POST\") {\n const u = new URL(req.url);\n // Meta webhook subscription handshake\n if (u.searchParams.get(\"hub.mode\") === \"subscribe\") {\n if (u.searchParams.get(\"hub.verify_token\") === META_VERIFY_TOKEN) {\n return new Response(u.searchParams.get(\"hub.challenge\") || \"\", { headers: { \"Content-Type\": \"text/plain\" } });\n }\n return new Response(\"forbidden\", { status: 403 });\n }\n if (u.searchParams.get(\"debug\") === \"salonbot2026\") {\n try {\n await ensureTable();\n const s = await sqlite.execute(`SELECT from_num, step, service, context, updated_at FROM sessions`);\n const b = await sqlite.execute(`SELECT id, from_num, service, slot, date, status, reminder_sent, followup_sent, rating, created_at FROM bookings ORDER BY created_at DESC LIMIT 50`);\n return Response.json({ now_ist: istNow(), sessions: s.rows, bookings: b.rows });\n } catch (e) { return Response.json({ error: String(e) }); }\n }\n if (u.searchParams.get(\"setfeedback\") === \"salonbot2026\") {\n // Debug-only test hook: simulate a delivered post-visit message.\n const f = u.searchParams.get(\"from\") || \"\";\n const svc = u.searchParams.get(\"service\") || \"\";\n const bid = u.searchParams.get(\"id\") || \"\";\n await setSession(f, \"feedback\", svc, bid);\n return Response.json({ ok: true, set: [f, \"feedback\", svc, bid] });\n }\n if (u.searchParams.get(\"tick\") === \"salonbot2026\") {\n try {\n const results = await runTick();\n return Response.json({ ok: true, now_ist: istNow(), actions: results });\n } catch (e) { return Response.json({ ok: false, error: String(e) }); }\n }\n return new Response(\"salon bot ok\");\n }\n let metaMode = false;\n try {\n const ct = req.headers.get(\"content-type\") || \"\";\n let from = \"unknown\";\n let bodyRaw = \"\";\n if (ct.includes(\"application/json\")) {\n metaMode = true;\n const payload = await req.json();\n const msg = payload?.entry?.[0]?.changes?.[0]?.value?.messages?.[0];\n if (!msg) return Response.json({ ok: true, ignored: true }); // statuses etc\n from = (\"whatsapp:+\" + String(msg.from)).replace(/\\s+/g, \"\");\n bodyRaw = String(msg?.text?.body || \"\").trim();\n } else {\n const form = await req.formData();\n from = String(form.get(\"From\") || \"unknown\").replace(/\\s+/g, \"\");\n bodyRaw = String(form.get(\"Body\") || \"\").trim();\n }\n const fromPretty = from.replace(\"whatsapp:\", \"\");\n const body = bodyRaw.toLowerCase();\n const now = istNow();\n\n const sess = await getSession(from);\n const history = await getHistory(from);\n await logMsg(from, \"user\", bodyRaw);\n let reply: string;\n let next = { step: sess.step, service: sess.service, context: sess.context };\n\n // Shared piece: offer slots for a chosen service + date, jumping to\n // tomorrow when today is wrapped. Returns reply text + session update.\n const offerSlots = (svcKey: string, dateISO: string): { reply: string; next: { step: string; service: string; context: string } } => {\n const svc = SERVICES[svcKey];\n let d = dateISO;\n let slots = slotsForDate(d, now);\n if (!slots.length) {\n d = isoAddDays(now.dateStr, 1);\n slots = SLOT_LIST.slice();\n return {\n reply: wrappedTodayAsk(svc.name, prettyDate(d)),\n next: { step: \"await_slot\", service: svcKey, context: d },\n };\n }\n return {\n reply: slotAsk(svc.name, prettyDate(d), slots),\n next: { step: \"await_slot\", service: svcKey, context: d },\n };\n };\n // Shared piece: stage a booking for customer confirmation. NOTHING is\n // written here - the booking is created only when they say yes.\n const stageBookingConfirm = (svcKey: string, slot: string, dateISO: string): { reply: string; next: { step: string; service: string; context: string } } => {\n const svc = SERVICES[svcKey];\n if (!slotStillOpen(slot, dateISO, now)) {\n const rem = slotsForDate(now.dateStr, now);\n if (rem.length) {\n return { reply: slotPassedAsk(svc.name, rem), next: { step: \"await_slot\", service: svcKey, context: now.dateStr } };\n }\n const d = isoAddDays(now.dateStr, 1);\n return { reply: wrappedTodayAsk(svc.name, prettyDate(d)), next: { step: \"await_slot\", service: svcKey, context: d } };\n }\n const pending = { a: \"book\", svc: svcKey, slot, date: dateISO };\n return {\n reply: confirmAsk(svc.name, svc.price, slot, prettyDate(dateISO)),\n next: { step: \"await_confirm\", service: \"\", context: JSON.stringify(pending) },\n };\n };\n\n // Small talk reply: warm human answer + gentle steer back to booking.\n // Flow state is left untouched - a \"thanks\" mid-booking doesn't lose the booking.\n const smalltalkReply = async (): Promise => {\n const custName = await getName(from);\n const t = normalizeTalk(body);\n const farewell = FAREWELL_RE.test(t);\n const steer = farewell\n ? \"\"\n : sess.step === \"await_slot\" && SERVICES[sess.service]\n ? \" Just tell me a time and I'll grab it for you.\"\n : sess.step === \"await_reschedule\"\n ? \" Tell me the new time and I'll move it.\"\n : sess.step === \"await_confirm\"\n ? \" Say yes to lock it in, or no to drop it.\"\n : \" What can I set up for you - haircut, hair spa, facial, mani-pedi?\";\n let ai = await aiReply(\n `(This message is small talk, not a salon question. Answer it the way a warm human receptionist texting would - one or two short, natural sentences${custName ? `; you may use their name, ${custName}, at most once` : \"\"}${farewell ? \"; they are saying goodbye, so wish them well\" : \", then gently steer back to booking\"}.) ` + bodyRaw,\n history,\n );\n if (ai && /HANDOFF/i.test(ai)) ai = null;\n let out = ai || cannedSmalltalk(body, custName);\n if (steer && !/\\?\\s*$/.test(out.trim()) && !/book|slot|service|appointment|set up|lock it/i.test(out)) out = out.replace(/\\s+$/, \"\") + steer;\n return out;\n };\n\n if (sess.step === \"feedback\" && /^[1-5]$/.test(body)) {\n // Post-visit rating arrived (deterministic: the follow-up message asked for 1-5).\n const rating = parseInt(body);\n await ensureTable();\n await sqlite.execute({ sql: `UPDATE bookings SET rating = ?, status = 'completed' WHERE id = ?`, args: [rating, sess.context] });\n if (rating >= 4) {\n reply = reviewNudge;\n await notifyOwner(\n `⭐ Happy customer: ${rating}/5 (${sess.service})`,\n `Customer ${fromPretty} rated their ${sess.service} visit ${rating}/5 (booking ${sess.context}) and got the Google review nudge.`,\n );\n } else {\n reply = serviceRecovery;\n await notifyOwner(\n `⚠️ Unhappy customer: ${rating}/5 (${sess.service}) - reach out!`,\n `Customer ${fromPretty} rated their ${sess.service} visit ${rating}/5 (booking ${sess.context}). Service recovery: reply to them on WhatsApp soon.`,\n );\n }\n next = { step: \"new\", service: \"\", context: \"\" };\n } else if (sess.step === \"await_confirm\") {\n // The deterministic yes/no gate: every natural-language state change\n // passes through here. The AI proposed nothing; code staged it; only the\n // customer's yes executes it.\n let pending: { a?: string; svc?: string; slot?: string; date?: string; id?: string; service?: string } | null = null;\n try { pending = JSON.parse(sess.context); } catch (_e) { /* bad context */ }\n if (!pending || !pending.a) {\n reply = greetingMsg(await getName(from));\n next = { step: \"new\", service: \"\", context: \"\" };\n } else if (YES_RE.test(body)) {\n if (pending.a === \"book\" && pending.svc && pending.slot && pending.date) {\n const svc = SERVICES[pending.svc];\n const id = \"GG-\" + (1000 + Math.floor(Math.random() * 9000));\n await saveBooking(id, from, svc.name, pending.slot, pending.date);\n reply = confirmation(svc, pending.slot, prettyDate(pending.date), id, await getName(from));\n next = { step: \"booked\", service: pending.svc, context: \"\" };\n await notifyOwner(\n `💇 New booking: ${svc.name} at ${pending.slot}`,\n `New booking at Glow & Grace:\\n\\nCustomer: ${fromPretty}\\nService: ${svc.name} - Rs.${svc.price}\\nSlot: ${pending.slot} on ${prettyDate(pending.date)}\\nBooking ID: ${id}\\n\\nReply to the customer on WhatsApp if needed.`,\n );\n } else if (pending.a === \"reschedule\" && pending.id && pending.slot) {\n await rescheduleBooking(pending.id, pending.slot, pending.date || \"\");\n reply = rescheduled(String(pending.service || \"\"), pending.slot, prettyDate(String(pending.date || \"\"), now.pretty), pending.id);\n next = { step: \"booked\", service: \"\", context: \"\" };\n await notifyOwner(\n `🔄 Booking moved: ${pending.service} now at ${pending.slot}`,\n `Customer ${fromPretty} rescheduled booking ${pending.id} (${pending.service}) to ${pending.slot} on ${prettyDate(String(pending.date || \"\"), now.pretty)}.`,\n );\n } else if (pending.a === \"cancel\" && pending.id) {\n await cancelBookingById(pending.id);\n reply = CANCEL(pending.id);\n next = { step: \"new\", service: \"\", context: \"\" };\n await notifyOwner(\n `❌ Booking cancelled: ${pending.service} at ${pending.slot}`,\n `Customer ${fromPretty} cancelled booking ${pending.id} (${pending.service} at ${pending.slot}).`,\n );\n } else {\n reply = greetingMsg(await getName(from));\n next = { step: \"new\", service: \"\", context: \"\" };\n }\n } else if (NO_RE.test(body) || body === \"cancel\") {\n reply = pendingDropped;\n next = pending.a === \"book\" ? { step: \"new\", service: \"\", context: \"\" } : { step: \"booked\", service: \"\", context: \"\" };\n } else if (isSmalltalk(body)) {\n // A pleasantry mid-confirm (\"thanks\", \"ok cool\") gets a human answer;\n // the pending booking stays staged for their yes/no.\n reply = await smalltalkReply();\n next = { step: \"await_confirm\", service: \"\", context: sess.context };\n } else {\n reply = confirmNudge;\n next = { step: \"await_confirm\", service: \"\", context: sess.context };\n }\n } else if ((body === \"9\" || body === \"cancel\") && (sess.step === \"booked\" || sess.step === \"await_reschedule\")) {\n const cancelled = await cancelLatestBooking(from);\n reply = CANCEL(cancelled ? cancelled.id : \"\");\n next = { step: \"new\", service: \"\", context: \"\" };\n await notifyOwner(\n `❌ Booking cancelled${cancelled ? `: ${cancelled.service} at ${cancelled.slot}` : \"\"}`,\n `Customer ${fromPretty} cancelled booking ${cancelled ? cancelled.id : \"\"} (${cancelled ? cancelled.service : \"?\"} at ${cancelled ? cancelled.slot : \"?\"}).`,\n );\n } else if (body === \"9\" || body === \"cancel\") {\n reply = noBookingFound;\n next = { step: sess.step, service: sess.service, context: sess.context };\n } else if ((body === \"8\" || body === \"reschedule\" || body === \"change\") && sess.step === \"booked\") {\n const bk = await latestBooking(from);\n if (bk) {\n reply = rescheduleMenu(bk.service, bk.id);\n next = { step: \"await_reschedule\", service: bk.service, context: bk.id };\n } else {\n reply = noBookingFound;\n next = { step: \"new\", service: \"\", context: \"\" };\n }\n } else if (sess.step === \"await_reschedule\" && SLOTS[body]) {\n const bk = await latestBooking(from);\n if (bk && bk.id === sess.context) {\n await rescheduleBooking(bk.id, SLOTS[body], bk.date || now.dateStr);\n reply = rescheduled(bk.service, SLOTS[body], prettyDate(bk.date, now.pretty) || now.pretty, bk.id);\n next = { step: \"booked\", service: bk.service, context: \"\" };\n await notifyOwner(\n `🔄 Booking moved: ${bk.service} now at ${SLOTS[body]}`,\n `Customer ${fromPretty} rescheduled booking ${bk.id} (${bk.service}) from ${bk.slot} to ${SLOTS[body]} on ${prettyDate(bk.date, now.pretty) || now.pretty}.`,\n );\n } else {\n reply = `That booking is no longer active. Want to book fresh? Just tell me the service and time.`;\n next = { step: \"new\", service: \"\", context: \"\" };\n }\n } else if (body === \"8\" || body === \"reschedule\" || body === \"change\") {\n reply = noBookingFound;\n next = { step: sess.step, service: sess.service, context: sess.context };\n } else if (SERVICES[body] && sess.step !== \"await_slot\" && sess.step !== \"await_reschedule\") {\n // Numbered service pick (menu fallback path). Honors any slot/date the\n // customer already mentioned in the awaiting step.\n let partial: { slot?: string; date?: string } | null = null;\n try { partial = JSON.parse(sess.context); } catch (_e) { /* plain context */ }\n if (sess.step === \"await_service\" && partial && partial.slot) {\n const d = partial.date || now.dateStr;\n const out = stageBookingConfirm(body, partial.slot, d);\n reply = out.reply; next = out.next;\n } else {\n const d = (partial && partial.date) || now.dateStr;\n const out = offerSlots(body, d);\n reply = out.reply; next = out.next;\n }\n } else if (sess.step === \"await_slot\" && SLOTS[body] && SERVICES[sess.service]) {\n // Numbered slot pick: stage for confirmation (nothing written yet).\n const out = stageBookingConfirm(sess.service, SLOTS[body], sess.context || now.dateStr);\n reply = out.reply; next = out.next;\n } else if (/price|rate|charge|cost|eshtu|estu|ಎಷ್ಟು|ಬೆಲೆ|kitna|kitne|कितना|कितने|evalavu|எவ்வளவு|entha|ఎంత|menu/.test(body)) {\n reply = WELCOME; next = { step: \"await_service\", service: \"\", context: \"\" };\n } else if ((/^((hi+|hello+|hey+|hai|namaste|namaskara|vanakkam|namaskaram)\\b|ಹಾಯ್|ಹಲೋ|ನಮಸ್ತೆ|ನಮಸ್ಕಾರ|हाय|हैलो|ஹாய்|வணக்கம்|హಾయ్|హలో|నమస్తె|నమస్కారం)/.test(body) || body.startsWith(\"join\")) && !regexParse(body)) {\n reply = greetingMsg(await getName(from)); next = { step: \"new\", service: \"\", context: \"\" };\n } else if (isSmalltalk(body)) {\n // Pleasantries and small talk: human answer + steer, never the handoff.\n reply = await smalltalkReply();\n next = { step: sess.step, service: sess.service, context: sess.context };\n } else {\n // Natural-language front door. The parser only classifies; all state\n // changes execute through the deterministic branches below.\n const parsed = (await parseMessage(bodyRaw, now, history)) || regexParse(body);\n let handled = false;\n if (parsed && parsed.name) await setName(from, parsed.name);\n\n if (parsed) {\n let svcKey = mapParsedService(parsed.service);\n let slot = resolveSlotLabel(parsed.time);\n let dateISO = resolveDateISO(parsed.date, now.dateStr);\n // Merge anything the customer already told us earlier in the flow.\n if (sess.step === \"await_slot\" && SERVICES[sess.service]) {\n svcKey = svcKey || sess.service;\n if (!dateISO) dateISO = sess.context || now.dateStr;\n if (slot) parsed.intent = \"book\";\n } else if (sess.step === \"await_service\") {\n try {\n const p = JSON.parse(sess.context);\n if (!slot && p.slot) slot = p.slot;\n if (!dateISO && p.date) dateISO = p.date;\n } catch (_e) { /* plain context */ }\n if (svcKey && parsed.intent !== \"cancel\" && parsed.intent !== \"reschedule\") parsed.intent = \"book\";\n }\n\n if (parsed.intent === \"smalltalk\") {\n reply = await smalltalkReply();\n next = { step: sess.step, service: sess.service, context: sess.context };\n handled = true;\n } else if (parsed.intent === \"greeting\") {\n reply = greetingMsg(await getName(from)); next = { step: \"new\", service: \"\", context: \"\" };\n handled = true;\n } else if (parsed.intent === \"book\") {\n handled = true;\n if (svcKey === \"hair_any\") {\n reply = hairAsk;\n next = { step: \"await_service\", service: \"\", context: JSON.stringify({ slot, date: dateISO }) };\n } else if (svcKey && slot) {\n const out = stageBookingConfirm(svcKey, slot, dateISO || now.dateStr);\n reply = out.reply; next = out.next;\n } else if (svcKey) {\n const out = offerSlots(svcKey, dateISO || now.dateStr);\n reply = out.reply; next = out.next;\n } else {\n reply = serviceAskMsg();\n next = { step: \"await_service\", service: \"\", context: JSON.stringify({ slot, date: dateISO }) };\n }\n } else if (parsed.intent === \"reschedule\") {\n const bk = await latestBooking(from);\n handled = true;\n if (!bk) {\n reply = noBookingFound;\n next = { step: \"new\", service: \"\", context: \"\" };\n } else if (slot) {\n const d = dateISO || bk.date || now.dateStr;\n const pending = { a: \"reschedule\", id: bk.id, service: bk.service, slot, date: d };\n reply = confirmMoveAsk(bk.service, bk.id, slot, prettyDate(d));\n next = { step: \"await_confirm\", service: \"\", context: JSON.stringify(pending) };\n } else {\n reply = rescheduleAskNatural(bk.service, bk.slot, prettyDate(bk.date, now.pretty) || now.pretty);\n next = { step: \"await_reschedule\", service: bk.service, context: bk.id };\n }\n } else if (parsed.intent === \"cancel\") {\n const bk = await latestBooking(from);\n handled = true;\n if (!bk) {\n reply = noBookingFound;\n next = { step: sess.step, service: sess.service, context: sess.context };\n } else {\n reply = cancelAskNatural(bk.service, bk.slot, prettyDate(bk.date, now.pretty) || now.pretty, bk.id);\n const pending = { a: \"cancel\", id: bk.id, service: bk.service, slot: bk.slot, date: bk.date };\n next = { step: \"await_confirm\", service: \"\", context: JSON.stringify(pending) };\n }\n }\n // query + other fall through to the shared Q&A / handoff below.\n }\n\n if (!handled && parsed && parsed.intent !== \"query\" && parsed.intent !== \"greeting\" &&\n (sess.step === \"await_service\" || sess.step === \"await_slot\")) {\n // Mid-flow: the customer is most likely answering the question we just\n // asked, even when the parser labels it \"other\". Extract the answer\n // deterministically; never hand off just for answering us.\n let ansSvc: string | null = null;\n if (/hair\\s*spa|\\bspa\\b|treatment/.test(body)) ansSvc = \"2\";\n else if (/hair\\s*cut|\\bcut\\b|trim/.test(body)) ansSvc = \"1\";\n else if (/facial|\\bface\\b|clean.?up/.test(body)) ansSvc = \"3\";\n else if (/mani|pedi|nail/.test(body)) ansSvc = \"4\";\n let ansSlot: string | null = null;\n if (/morning/.test(body)) ansSlot = \"11:30 AM\";\n else if (/afternoon|after lunch|\\blunch\\b/.test(body)) ansSlot = \"2:00 PM\";\n else if (/evening|tonight/.test(body)) ansSlot = \"5:30 PM\";\n else if (/11[:. ]?30/.test(body)) ansSlot = \"11:30 AM\";\n else if (/\\b2[:. ]?00\\s?(pm)?\\b/.test(body)) ansSlot = \"2:00 PM\";\n else if (/5[:. ]?30/.test(body)) ansSlot = \"5:30 PM\";\n let partial: { slot?: string; date?: string } | null = null;\n try { partial = JSON.parse(sess.context); } catch (_e) { /* plain context */ }\n\n if (sess.step === \"await_slot\" && ansSvc && ansSvc !== sess.service) {\n // Changed their mind about the service mid-pick.\n const d = resolveDateISO(parsed.date, now.dateStr) || sess.context || now.dateStr;\n const out = offerSlots(ansSvc, d);\n reply = out.reply; next = out.next; handled = true;\n } else if (sess.step === \"await_slot\" && SERVICES[sess.service] && ansSlot) {\n const out = stageBookingConfirm(sess.service, ansSlot, sess.context || now.dateStr);\n reply = out.reply; next = out.next; handled = true;\n } else if (sess.step === \"await_service\" && ansSvc) {\n const slot = resolveSlotLabel(parsed.time) || ansSlot || (partial && partial.slot) || null;\n const d = resolveDateISO(parsed.date, now.dateStr) || (partial && partial.date) || now.dateStr;\n const out = slot ? stageBookingConfirm(ansSvc, slot, d) : offerSlots(ansSvc, d);\n reply = out.reply; next = out.next; handled = true;\n } else if (sess.step === \"await_service\" && ansSlot) {\n // A time but no service - remember the time, ask the service again.\n reply = serviceAskMsg();\n next = { step: \"await_service\", service: \"\", context: JSON.stringify({ slot: ansSlot, date: (partial && partial.date) || resolveDateISO(parsed.date, now.dateStr) }) };\n handled = true;\n } else if (sess.step === \"await_service\") {\n // Unreadable answer - ask again gently, no human handoff for this.\n reply = serviceAskMsg();\n next = { step: \"await_service\", service: \"\", context: sess.context };\n handled = true;\n } else if (SERVICES[sess.service]) {\n const d = sess.context || now.dateStr;\n const rem = slotsForDate(d, now);\n reply = slotAsk(SERVICES[sess.service].name, prettyDate(d), rem.length ? rem : SLOT_LIST);\n next = { step: \"await_slot\", service: sess.service, context: sess.context };\n handled = true;\n }\n }\n\n if (!handled && parsed && parsed.intent === \"other\") {\n\n reply = HANDOFF;\n next = sess.step === \"booked\" ? { step: \"booked\", service: sess.service, context: sess.context } : { step: \"await_service\", service: \"\", context: \"\" };\n await notifyOwner(\n \"🔔 Salon bot: customer needs a human\",\n `WhatsApp ${fromPretty} asked:\\n\"${bodyRaw}\"\\n\\nReply to them on WhatsApp.`,\n );\n } else if (!handled) {\n // Question (or parser unavailable): answer warmly from real salon data,\n // hand off to a human when the answer isn't in the data.\n const hintSvc = SERVICES[sess.service] ? SERVICES[sess.service].name : \"\";\n const custName = await getName(from);\n const ctxBits: string[] = [];\n if (custName) ctxBits.push(`The customer's name is ${custName}.`);\n if (hintSvc) ctxBits.push(`The customer is mid-booking a ${hintSvc}, so \"it\" or \"this\" refers to that.`);\n const ai = await aiReply((ctxBits.length ? `(Context: ${ctxBits.join(\" \")}) ` : \"\") + bodyRaw, history);\n if (ai && !/HANDOFF/i.test(ai)) {\n reply = ai;\n if (sess.step === \"await_slot\" && SERVICES[sess.service]) {\n reply += `\\n\\nJust tell me a time and I'll grab it for you.`;\n } else if (sess.step === \"await_reschedule\") {\n reply += `\\n\\nTell me the new time and I'll move it.`;\n }\n next = { step: sess.step, service: sess.service, context: sess.context };\n } else {\n reply = HANDOFF;\n next = sess.step === \"booked\" ? { step: \"booked\", service: sess.service, context: sess.context } : { step: \"await_service\", service: \"\", context: \"\" };\n await notifyOwner(\n \"🔔 Salon bot: customer needs a human\",\n `WhatsApp ${fromPretty} asked:\\n\"${bodyRaw}\"\\n\\nReply to them on WhatsApp.`,\n );\n }\n }\n }\n\n await logMsg(from, \"assistant\", reply);\n await setSession(from, next.step, next.service, next.context);\n if (metaMode) {\n const s = await sendWhatsApp(from, reply);\n return Response.json({ ok: s.ok, detail: s.detail });\n }\n return twiml(reply);\n } catch (err) {\n if (metaMode) return Response.json({ ok: false, error: String(err).slice(0, 200) });\n return twiml(\"Sorry - something glitched on my end. Could you send that again?\");\n }\n}\n",[144],"052a7ddc-3736-4bcc-9104-d51fb4e09a7e","index.tsx","5d7a1976-a901-11f1-a20a-1607ee4eb77e",1,["D",1788595875329],"import { sqlite } from \"https://esm.town/v/std/sqlite\";\nimport { email } from \"https://esm.town/v/std/email\";\n\nconst SERVICES: Record = {\n \"1\": { name: \"Haircut\", kn: \"ಹೇರ್\\u200cಕಟ್\", price: 800 },\n \"2\": { name: \"Hair Spa\", kn: \"ಹೇರ್ ಸ್ಪಾ\", price: 1500 },\n \"3\": { name: \"Facial\", kn: \"ಫೇಶಿಯಲ್\", price: 1200 },\n \"4\": { name: \"Manicure + Pedicure\", kn: \"ಮ್ಯಾನಿಕ್ಯೂರ್ + ಪೆಡಿಕ್ಯೂರ್\", price: 1000 },\n};\nconst SLOTS: Record = { \"1\": \"11:30 AM\", \"2\": \"2:00 PM\", \"3\": \"5:30 PM\" };\n\nconst WELCOME = `Namaste 🙏 Welcome to *Glow & Grace Salon*, HSR Layout!\nನಮಸ್ತೆ! ಗ್ಲೋ & ಗ್ರೇಸ್ ಸಲೂನ್\\u200cಗೆ ಸ್ವಾಗತ ✨\n\n*Our services / ನಮ್ಮ ಸರ್ವೀಸ್\\u200cಗಳು:*\n1️⃣ Haircut - ₹800\n2️⃣ Hair Spa - ₹1,500\n3️⃣ Facial - ₹1,200\n4️⃣ Manicure + Pedicure - ₹1,000\n\nReply with a number to book.\nಬುಕ್ ಮಾಡಲು ನಂಬರ್ ಟೈಪ್ ಮಾಡಿ.`;\n\nconst slotMenu = (s: { name: string; kn: string; price: number }) =>\n `Great choice! 💇 *${s.name}* - ₹${s.price}\n${s.kn} - ₹${s.price}\n\n*Available slots today / ಇಂದು ಖಾಲಿ ಇರುವ ಸಮಯ:*\n1️⃣ 11:30 AM\n2️⃣ 2:00 PM\n3️⃣ 5:30 PM\n\nReply with a number to pick your slot.\nಸಮಯ ಆಯ್ದುಕೊಳ್ಳಲು ನಂಬರ್ ಟೈಪ್ ಮಾಡಿ.`;\n\nconst confirmation = (s: { name: string }, slot: string, dateStr: string) =>\n `✅ *Booked!* ${s.name} at ${slot} on ${dateStr}.\nನಿಮ್ಮ ಅಪಾಯಿಂಟ್\\u200cಮೆಂಟ್ ಕನ್ಫರ್ಮ್ ಆಯಿತು! 🎉\n\n📍 Glow & Grace Salon, 27th Main, HSR Layout\nShow this message at the counter. Pay at the salon.\n\nReply *9* to cancel. Anything else, just ask!\nರದ್ದು ಮಾಡಲು 9 ಟೈಪ್ ಮಾಡಿ.`;\n\nconst HANDOFF = `Good question! I'm not completely sure about that one - our team will take over and reply to you shortly. 🙏\nಖಚಿತವಾಗಿ ಗೊತ್ತಿಲ್ಲ - ನಮ್ಮ ಟೀಮ್ ಶೀಘ್ರದಲ್ಲೇ ರಿಪ್ಲೈ ಮಾಡುತ್ತಾರೆ.\n\nMeanwhile reply *1-4* to book, or *menu* to see prices again.`;\n\nconst CANCEL = `Done, your booking is cancelled. ✅\nನಿಮ್ಮ ಬುಕಿಂಗ್ ರದ್ದು ಆಯಿತು.\nReply *hi* anytime to book again!`;\n\nfunction twiml(msg: string): Response {\n const esc = msg.replace(/&/g, \"&\").replace(//g, \">\");\n return new Response(\n `${esc}`,\n { headers: { \"Content-Type\": \"text/xml\" } },\n );\n}\n\nlet tableReady = false;\nasync function ensureTable() {\n if (tableReady) return;\n await sqlite.execute(\n `CREATE TABLE IF NOT EXISTS sessions (from_num TEXT PRIMARY KEY, step TEXT, service TEXT, updated_at INTEGER)`,\n );\n tableReady = true;\n}\nasync function getSession(from: string) {\n await ensureTable();\n const r = await sqlite.execute({\n sql: `SELECT step, service FROM sessions WHERE from_num = ?`,\n args: [from],\n });\n if (r.rows && r.rows.length) return { step: String(r.rows[0][0]), service: String(r.rows[0][1] || \"\") };\n return { step: \"new\", service: \"\" };\n}\nasync function setSession(from: string, step: string, service: string) {\n await ensureTable();\n await sqlite.execute({\n sql: `INSERT INTO sessions (from_num, step, service, updated_at) VALUES (?, ?, ?, ?)\n ON CONFLICT(from_num) DO UPDATE SET step=excluded.step, service=excluded.service, updated_at=excluded.updated_at`,\n args: [from, step, service, Date.now()],\n });\n}\n\nexport default async function (req: Request): Promise {\n if (req.method !== \"POST\") return new Response(\"salon bot ok\");\n try {\n const form = await req.formData();\n const from = String(form.get(\"From\") || \"unknown\");\n const bodyRaw = String(form.get(\"Body\") || \"\").trim();\n const body = bodyRaw.toLowerCase();\n const dateStr = new Intl.DateTimeFormat(\"en-IN\", {\n weekday: \"long\", day: \"numeric\", month: \"long\", timeZone: \"Asia/Kolkata\",\n }).format(new Date());\n\n const sess = await getSession(from);\n let reply: string;\n let next = { step: sess.step, service: sess.service };\n\n if (body === \"9\" && sess.step === \"booked\") {\n reply = CANCEL; next = { step: \"new\", service: \"\" };\n } else if (sess.step === \"await_service\" && SERVICES[body]) {\n reply = slotMenu(SERVICES[body]); next = { step: \"await_slot\", service: body };\n } else if (sess.step === \"await_slot\" && SLOTS[body] && SERVICES[sess.service]) {\n reply = confirmation(SERVICES[sess.service], SLOTS[body], dateStr); next = { step: \"booked\", service: sess.service };\n } else if (/price|rate|charge|cost|eshtu|estu|ಎಷ್ಟು|ಬೆಲೆ|kitna|कितना|menu|price/.test(body)) {\n reply = WELCOME; next = { step: \"await_service\", service: \"\" };\n } else if (/book|appointment|slot|ಬುಕ್|ಅಪಾಯಿಂಟ/.test(body)) {\n reply = WELCOME; next = { step: \"await_service\", service: \"\" };\n } else if (/^(hi+|hello+|hey+|hai|namaste|namaskara|ಹಾಯ್|ಹಲೋ|ನಮಸ್ತೆ|ನಮಸ್ಕಾರ)/.test(body) || body.startsWith(\"join\") || sess.step === \"new\") {\n reply = WELCOME; next = { step: \"await_service\", service: \"\" };\n } else if (sess.step === \"await_service\") {\n reply = WELCOME;\n } else if (sess.step === \"await_slot\" && SERVICES[sess.service]) {\n reply = slotMenu(SERVICES[sess.service]);\n } else {\n reply = HANDOFF; next = { step: \"await_service\", service: \"\" };\n try {\n await email({\n subject: \"🔔 Salon bot: customer needs a human\",\n text: `WhatsApp ${from.replace(\"whatsapp:\", \"\")} asked:\\n\"${bodyRaw}\"\\n\\nReply to them on WhatsApp.`,\n });\n } catch (e) { /* best effort */ }\n }\n\n await setSession(from, next.step, next.service);\n return twiml(reply);\n } catch (err) {\n return twiml(\"Sorry, something went wrong on our side. Please try again! 🙏\");\n }\n}",[151],"b95ffea7-30ea-44d8-bbf6-cfed92cc47c4",["D",1789033343388],[28],"pulls","branches","forks","envVars",{"_167":169,"_170":62},"connections",{"_167":62,"_168":62},"count","unfilledCount",7,"emptyCount",{"_43":157,"_32":28,"_30":31,"_135":-5,"_41":42,"_40":14,"_137":25,"_38":185,"_13":153,"_33":34,"_35":37,"_24":25,"_141":-5,"_176":186,"_27":187},{"_43":150,"_32":151,"_30":152,"_135":-5,"_41":42,"_40":153,"_137":58,"_38":182,"_13":62,"_33":20,"_35":155,"_24":25,"_141":-5,"_176":183,"_27":184},{"_43":143,"_32":144,"_30":56,"_135":-5,"_41":42,"_40":145,"_137":58,"_38":179,"_13":147,"_33":34,"_35":148,"_24":25,"_141":-5,"_176":180,"_27":181},{"_43":132,"_32":133,"_30":134,"_135":-5,"_41":42,"_40":136,"_137":58,"_38":175,"_13":62,"_33":139,"_35":140,"_24":25,"_141":-5,"_176":177,"_27":178},["D",1788607212085],"children",[],[133],["D",1788945003725],[],[144],["D",1788595875329],[],[151],["D",1789033343388],[],[28],["D",1788595835206],["D",1789476648181],{"_99":98,"_106":101},{"_99":98,"_100":101,"_102":101,"_18":54,"_103":104,"_105":25},{"_13":88,"_32":89,"_43":42,"_90":44,"_91":-5,"_92":-5,"_93":-5,"_94":-5,"_95":-5,"_96":45,"_97":98},"ctx",{"_81":-5,"_125":226,"_227":228,"_229":230,"_231":25,"_232":25,"_233":25,"_234":58,"_235":-5,"_236":-7,"_237":-7,"_238":62,"_239":25,"_240":25,"_241":-5,"_242":25,"_243":25,"_244":25,"_245":-5},"ENV",{"_197":198,"_199":200,"_201":89,"_202":203,"_204":205,"_206":207,"_208":209,"_210":211,"_212":213,"_214":215,"_216":217,"_218":219,"_220":221,"_222":223,"_224":225},"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"]

Diff · v33