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