[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_154":155,"_156":157},"routes/_app.x.$handle.$name",{"_95":94,"_32":45,"_103":85,"_27":53,"_13":14,"_104":-5,"_11":105,"_106":107,"_108":109,"_110":111,"_112":113,"_20":-5,"_114":-5,"_115":-5,"_116":25,"_117":118,"_119":120,"_121":-5,"_122":-5,"_123":124},"routes/_app.x.$handle.$name.branch.$branch.version.$version.diff",{"_11":12,"_13":14,"_15":16,"_17":-5,"_18":-5},"project",{"_43":44,"_32":45,"_38":46,"_47":-5,"_48":25,"_49":50,"_51":50,"_52":53,"_54":-5,"_18":55,"_56":-5,"_57":25,"_58":-5,"_59":-5,"_60":61,"_62":63,"_64":-5,"_65":-5,"_66":-5,"_67":-5,"_68":69,"_70":69,"_71":72,"_73":72,"_74":72,"_75":69,"_76":69,"_77":78,"_79":80,"_81":82,"_83":25},"version",28,"changes",[19],"aiChatInfo","userId",{"_20":21,"_22":23,"_24":25,"_26":25,"_27":28,"_29":28},"file",{"_30":31,"_32":28,"_33":34,"_35":37,"_38":39,"_40":14,"_41":42,"_24":25},"previous",{"_30":31,"_32":28,"_33":34,"_35":36},"deleted",false,"deletedHere","path","main.ts","latestPath","fileId","74eb91e2-5ec5-11f1-b611-1607ee4eb77e","name","fileType","http","content","// ============================================================================\n// GoodBeetle WhatsApp Consultation Bot — VAL TOWN (HTTP val)\n// DATABASE: Supabase (Postgres). Razorpay payments built in.\n// ----------------------------------------------------------------------------\n// Create this as an *HTTP* val. Val Town gives it a public URL like:\n// https://--goodbeetle_bot.web.val.run\n// Paste that URL into Meta as the webhook Callback URL.\n//\n// SECRETS — set in Val Town → Settings → Environment Variables:\n// WHATSAPP_TOKEN = Meta permanent System User token\n// SUPABASE_URL = https://.supabase.co\n// SUPABASE_SERVICE_KEY = Supabase **service_role** key (NOT the anon key!)\n// OPENAI_KEY = OpenAI API key\n// META_VERIFY_TOKEN = any word YOU choose (type the same word in Meta)\n// PUBLIC_URL = this val's own URL (for Razorpay callback). Optional.\n// RAZORPAY_KEY_ID = Razorpay Key ID (optional — payments skip if unset)\n// RAZORPAY_KEY_SECRET = Razorpay Key Secret (optional)\n//\n// IMPORTANT: run the schema in supabase_schema.sql once before going live.\n// ============================================================================\n\nimport { createClient } from \"npm:@supabase/supabase-js@2\";\n\n// ---- Secrets ---------------------------------------------------------------\nconst WA_TOKEN = Deno.env.get(\"WHATSAPP_TOKEN\")!;\nconst SUPABASE_URL = Deno.env.get(\"SUPABASE_URL\")!;\nconst SUPABASE_SERVICE_KEY = Deno.env.get(\"SUPABASE_SERVICE_KEY\")!;\nconst OPENAI_KEY = Deno.env.get(\"OPENAI_KEY\")!;\nconst VERIFY_TOKEN = Deno.env.get(\"META_VERIFY_TOKEN\")!;\nconst RZP_KEY_ID = Deno.env.get(\"RAZORPAY_KEY_ID\") || \"\";\nconst RZP_SECRET = Deno.env.get(\"RAZORPAY_KEY_SECRET\") || \"\";\nconst PUBLIC_URL =\n Deno.env.get(\"PUBLIC_URL\") ||\n \"https://goodbeetle--74eb91e25ec511f1b6111607ee4eb77e.web.val.run\";\n\n// ---- Supabase client (service_role bypasses RLS — keep server-side only) ----\nconst sb = createClient(SUPABASE_URL, SUPABASE_SERVICE_KEY, {\n auth: { persistSession: false },\n});\n\n// ---- Config ----------------------------------------------------------------\nconst PHONE_NUMBER_ID = \"980400758497769\";\nconst WA_URL = `https://graph.facebook.com/v18.0/${PHONE_NUMBER_ID}/messages`;\nconst ADMIN_PHONE = \"919354052769\";\nconst SESSION_FEE_PAISE = 49900; // ₹499 default (overridden per-pro by \"Rate\")\n\n// Logical table keys (used as keys into TABLE_MAP below).\nconst T_USERS = \"users\";\nconst T_PROS = \"professionals\";\nconst T_SESSIONS = \"sessions\";\nconst T_WAITLIST = \"waitlist\";\nconst T_LOGS = \"interaction_logs\";\nconst T_ERRORS = \"error_logs\";\n\nconst CATEGORIES = [\n \"Legal\", \"Tax & GST\", \"Startup & Compliance\", \"Tech\", \"Fitness\",\n \"Nutrition\", \"HR & Labour\", \"Marketing\", \"Product\", \"Astrology\", \"Vastu\",\n];\nconst CAT_BY_ID: Record = {\n legal: \"Legal\", tax: \"Tax & GST\", startup: \"Startup & Compliance\",\n tech: \"Tech\", fitness: \"Fitness\", nutrition: \"Nutrition\",\n hr: \"HR & Labour\", marketing: \"Marketing\", product: \"Product\",\n astrology: \"Astrology\", vastu: \"Vastu\",\n};\n\n// ============================================================================\n// PHONE NORMALIZATION — the single most important fix.\n// Everything (store, lookup, send) uses digits-only so a number always\n// matches itself regardless of \"+\", spaces, or dashes.\n// ============================================================================\nconst digits = (p?: string | null): string => (p || \"\").replace(/[^0-9]/g, \"\");\n\n// Builds a Supabase \".or()\" filter that matches a phone stored either as\n// \"919...\" or \"+919...\" — so legacy rows (with \"+\") still resolve.\nconst phoneOr = (col: string, phone: string): string => {\n const d = digits(phone);\n return `${col}.eq.${d},${col}.eq.+${d}`;\n};\n\n// ============================================================================\n// HTTP ENTRYPOINT\n// ============================================================================\nexport default async function (req: Request): Promise {\n const url = new URL(req.url);\n\n // Meta webhook verification (GET) — also serves Razorpay GET callback.\n if (req.method === \"GET\") {\n if (url.pathname.includes(\"/payment\")) {\n try {\n await handlePaymentCallback({\n razorpay_payment_link_id: url.searchParams.get(\"razorpay_payment_link_id\"),\n razorpay_payment_link_status: url.searchParams.get(\"razorpay_payment_link_status\"),\n buyer_phone: url.searchParams.get(\"buyer_phone\"),\n });\n } catch (e: any) {\n console.error(\"payment callback error:\", e?.message);\n }\n return new Response(\"Payment received. You can return to WhatsApp.\", { status: 200 });\n }\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) {\n console.log(\"Webhook verification OK\");\n return new Response(challenge ?? \"\", { status: 200 });\n }\n return new Response(\"Forbidden\", { status: 403 });\n }\n\n // Incoming POST: WhatsApp message OR Razorpay webhook.\n if (req.method === \"POST\") {\n let body: any = {};\n try { body = await req.json(); } catch (_) { /* ignore */ }\n\n if (url.pathname.includes(\"/payment\")) {\n try { await handlePaymentCallback(body); }\n catch (e: any) { console.error(\"payment webhook error:\", e?.message); }\n return new Response(\"OK\", { status: 200 });\n }\n\n console.log(\"RAW INCOMING:\", JSON.stringify(body).slice(0, 500));\n try { await handleMessage(body); }\n catch (e: any) { console.error(\"handleMessage error:\", e?.message || e, e?.stack); }\n return new Response(\"EVENT_RECEIVED\", { status: 200 });\n }\n\n return new Response(\"OK\", { status: 200 });\n}\n\n// ============================================================================\n// WHATSAPP SEND HELPERS — every \"to\" is normalized to digits-only.\n// ============================================================================\nasync function waPost(payload: any): Promise {\n try {\n const r = await fetch(WA_URL, {\n method: \"POST\",\n headers: { Authorization: `Bearer ${WA_TOKEN}`, \"Content-Type\": \"application/json\" },\n body: JSON.stringify(payload),\n });\n const d = await r.json();\n if (!r.ok) { console.error(\"waPost FAILED\", r.status, JSON.stringify(d)); return false; }\n console.log(\"waPost OK to\", payload.to, \"type\", payload.type);\n return true;\n } catch (e: any) {\n console.error(\"waPost EXCEPTION:\", e?.message);\n return false;\n }\n}\n\nasync function sendText(to: string, text: string): Promise {\n const dest = digits(to);\n console.log(`sendText → ${dest}: ${text.slice(0, 80)}`);\n return waPost({ messaging_product: \"whatsapp\", to: dest, type: \"text\", text: { body: text } });\n}\n\nasync function sendButtons(\n to: string, body: string, buttons: { id: string; title: string }[],\n): Promise {\n const dest = digits(to);\n console.log(`sendButtons → ${dest}: ${body.slice(0, 60)}`);\n return waPost({\n messaging_product: \"whatsapp\",\n to: dest,\n type: \"interactive\",\n interactive: {\n type: \"button\",\n body: { text: body },\n action: {\n buttons: buttons.slice(0, 3).map((b) => ({\n type: \"reply\",\n reply: { id: b.id, title: b.title.slice(0, 20) }, // WA limit: 20 chars\n })),\n },\n },\n });\n}\n\nasync function sendList(\n to: string, header: string, body: string, buttonLabel: string,\n rows: { id: string; title: string; description?: string }[],\n): Promise {\n const dest = digits(to);\n console.log(`sendList → ${dest}: ${body.slice(0, 60)}`);\n return waPost({\n messaging_product: \"whatsapp\",\n to: dest,\n type: \"interactive\",\n interactive: {\n type: \"list\",\n header: header ? { type: \"text\", text: header.slice(0, 60) } : undefined,\n body: { text: body },\n action: {\n button: buttonLabel.slice(0, 20),\n sections: [{\n title: \"Categories\",\n rows: rows.slice(0, 10).map((r) => ({\n id: r.id,\n title: r.title.slice(0, 24), // WA limit: 24 chars\n description: r.description?.slice(0, 72), // WA limit: 72 chars\n })),\n }],\n },\n },\n });\n}\n\nasync function sendProTemplate(to: string, category: string): Promise {\n const dest = digits(to);\n console.log(`sendProTemplate → ${dest}, category: ${category}`);\n const ok = await waPost({\n messaging_product: \"whatsapp\",\n to: dest,\n type: \"template\",\n template: {\n name: \"professional_acceptance\",\n language: { code: \"en\" },\n components: [{ type: \"body\", parameters: [{ type: \"text\", text: category }] }],\n },\n });\n return ok;\n}\n\n// ============================================================================\n// SUPABASE DATA LAYER\n// Returns Airtable-shaped objects { id, fields } so the state machine reads\n// familiar field names. Column mapping lives in TABLE_MAP.\n// ============================================================================\nconst first = (rows: any[] | null) => (rows && rows.length ? rows[0] : null);\n\nfunction userObj(r: any) {\n return r ? {\n id: r.id,\n fields: {\n \"Phone Number\": r.phone_number,\n \"Name\": r.name,\n \"Active Session?\": r.active_session,\n \"Bot_State\": r.bot_state,\n \"Pending_Pro_ID\": r.pending_pro_id,\n \"Pending_Pro_Phone\": r.pending_pro_phone,\n \"Pending_Category\": r.pending_category,\n \"Pending_Query\": r.pending_query,\n },\n } : null;\n}\nfunction proObj(r: any) {\n return r ? {\n id: r.id,\n fields: {\n \"Pro Phone\": r.pro_phone,\n \"Pro Name\": r.pro_name,\n \"Specialization\": r.specialization,\n \"Category (from Specialization)\": r.categories || [],\n \"Availability\": r.available,\n \"Rating\": r.rating,\n \"Lifetime Ratings\": r.lifetime_ratings,\n \"Rate\": r.rate,\n },\n } : null;\n}\nfunction sessionObj(r: any) {\n return r ? {\n id: r.id,\n fields: {\n \"Pro Phone\": r.pro_phone,\n \"Status\": r.status,\n \"Rating\": r.rating,\n \"buyer_phone\": r.buyer_phone,\n \"category\": r.category,\n \"query\": r.query,\n \"Users\": r.user_id ? [r.user_id] : [],\n \"Professionals\": r.pro_id ? [r.pro_id] : [],\n },\n } : null;\n}\nconst passObj = (r: any) => (r ? { id: r.id, fields: {} } : null);\n\nconst TABLE_MAP: Record; toObj: (r: any) => any }> = {\n [T_USERS]: {\n pg: \"users\", toObj: userObj,\n toCol: {\n \"Phone Number\": \"phone_number\", \"Name\": \"name\", \"Active Session?\": \"active_session\",\n \"Bot_State\": \"bot_state\", \"Pending_Pro_ID\": \"pending_pro_id\",\n \"Pending_Pro_Phone\": \"pending_pro_phone\", \"Pending_Category\": \"pending_category\",\n \"Pending_Query\": \"pending_query\",\n \"Created Date\": \"created_at\",\n },\n },\n [T_PROS]: {\n pg: \"professionals\", toObj: proObj,\n toCol: {\n \"Pro Phone\": \"pro_phone\", \"Pro Name\": \"pro_name\", \"Specialization\": \"specialization\",\n \"Category (from Specialization)\": \"categories\", \"Availability\": \"available\",\n \"Rating\": \"rating\", \"Lifetime Ratings\": \"lifetime_ratings\", \"Rate\": \"rate\",\n },\n },\n [T_SESSIONS]: {\n pg: \"sessions\", toObj: sessionObj,\n toCol: {\n \"Users\": \"user_id\", \"Professionals\": \"pro_id\", \"Pro Phone\": \"pro_phone\",\n \"Status\": \"status\", \"Rating\": \"rating\", \"IdleWarned\": \"idle_warned\",\n \"buyer_phone\": \"buyer_phone\", \"Phone Number (from Users)\": \"buyer_phone\",\n \"category\": \"category\", \"query\": \"query\",\n },\n },\n [T_WAITLIST]: {\n pg: \"waitlist\", toObj: passObj,\n toCol: {\n \"User_Phone\": \"user_phone\", \"Category\": \"category\", \"Query\": \"query\",\n \"Status\": \"status\", \"Joined_At\": \"joined_at\",\n },\n },\n [T_LOGS]: {\n pg: \"interaction_logs\", toObj: passObj,\n toCol: {\n \"Sessions\": \"session_id\", \"Direction\": \"direction\", \"Content\": \"content\",\n \"Timestamp\": \"created_at\",\n },\n },\n [T_ERRORS]: {\n pg: \"error_logs\", toObj: passObj,\n toCol: {\n \"Workflow\": \"workflow\", \"Failed_Node\": \"failed_node\", \"Error_Message\": \"error_message\",\n \"Timestamp\": \"created_at\", \"Sender_Phone\": \"sender_phone\", \"Raw_Message\": \"raw_message\",\n },\n },\n};\n\n// FK columns that take the first element of an Airtable-style [id] array.\nconst ARRAY_TO_SCALAR = new Set([\"user_id\", \"pro_id\", \"session_id\"]);\n\nfunction translateFields(tableId: string, fields: Record) {\n const map = TABLE_MAP[tableId];\n const out: Record = {};\n for (const [k, v] of Object.entries(fields)) {\n const col = map.toCol[k];\n if (!col) { console.warn(`DB: skipping unknown field \"${k}\" on ${map.pg}`); continue; }\n out[col] = (ARRAY_TO_SCALAR.has(col) && Array.isArray(v)) ? (v[0] ?? null) : v;\n }\n return out;\n}\n\n// Generic create. Returns null on failure (callers MUST check), so we never\n// pretend a row exists when the insert actually failed.\nasync function atCreate(tableId: string, fields: any): Promise {\n const map = TABLE_MAP[tableId];\n const { data, error } = await sb.from(map.pg).insert(translateFields(tableId, fields)).select();\n if (error) { console.error(\"atCreate FAILED\", map.pg, error.message); return null; }\n return map.toObj(first(data));\n}\nasync function atUpdate(tableId: string, id: string, fields: any): Promise {\n const map = TABLE_MAP[tableId];\n const { data, error } = await sb.from(map.pg).update(translateFields(tableId, fields)).eq(\"id\", id).select();\n if (error) { console.error(\"atUpdate FAILED\", map.pg, id, error.message); return null; }\n return map.toObj(first(data));\n}\n\n// ---- Named lookups (all phone-format tolerant) -----------------------------\nasync function findUserByPhone(phone: string) {\n const { data, error } = await sb.from(\"users\").select(\"*\").or(phoneOr(\"phone_number\", phone)).limit(1);\n if (error) { console.error(\"findUserByPhone\", error.message); return null; }\n return userObj(first(data));\n}\nasync function findProByPhone(phone: string) {\n const { data, error } = await sb.from(\"professionals\").select(\"*\").or(phoneOr(\"pro_phone\", phone)).limit(1);\n if (error) { console.error(\"findProByPhone\", error.message); return null; }\n return proObj(first(data));\n}\nasync function findSessionByProStatus(proPhone: string, status: string) {\n const { data, error } = await sb.from(\"sessions\").select(\"*\").or(phoneOr(\"pro_phone\", proPhone)).eq(\"status\", status).limit(1);\n if (error) { console.error(\"findSessionByProStatus\", error.message); return null; }\n return sessionObj(first(data));\n}\nasync function findActiveOrPausedByPro(proPhone: string) {\n const { data, error } = await sb.from(\"sessions\").select(\"*\").or(phoneOr(\"pro_phone\", proPhone)).in(\"status\", [\"Active\", \"Paused\"]).limit(1);\n if (error) { console.error(\"findActiveOrPausedByPro\", error.message); return null; }\n return sessionObj(first(data));\n}\nasync function findSessionByUserStatus(userId: string, status: string) {\n const { data, error } = await sb.from(\"sessions\").select(\"*\").eq(\"user_id\", userId).eq(\"status\", status).limit(1);\n if (error) { console.error(\"findSessionByUserStatus\", error.message); return null; }\n return sessionObj(first(data));\n}\n\n// Resolve the buyer's phone for a session. Prefer the denormalized column;\n// fall back to the linked user row. RELAY-FIX: guarantees pro→buyer works.\nasync function getBuyerPhone(session: any): Promise {\n let phone = session?.fields?.[\"buyer_phone\"] || null;\n if (!phone) {\n const userId = session?.fields?.[\"Users\"]?.[0];\n if (userId) {\n const { data } = await sb.from(\"users\").select(\"phone_number\").eq(\"id\", userId).limit(1);\n phone = first(data)?.phone_number || null;\n }\n }\n const out = phone ? digits(phone) : null;\n console.log(\"getBuyerPhone:\", out);\n return out;\n}\n\nasync function findPro(category: string, excludePhone?: string): Promise {\n let q = sb.from(\"professionals\").select(\"*\").contains(\"categories\", [category]).eq(\"available\", true);\n if (excludePhone) {\n const d = digits(excludePhone);\n q = q.neq(\"pro_phone\", d).neq(\"pro_phone\", `+${d}`);\n }\n const { data, error } = await q.order(\"rating\", { ascending: false }).limit(1);\n if (error) { console.error(\"findPro FAILED\", category, error.message); return null; }\n return proObj(first(data));\n}\n\nasync function logInteraction(sessionId: string, direction: string, content: string) {\n try {\n await atCreate(T_LOGS, {\n Sessions: [sessionId], Direction: direction, Content: content,\n Timestamp: new Date().toISOString(),\n });\n } catch (_) { /* logging must never break a relay */ }\n}\nasync function logError(node: string, msg: string, sender: string, raw: string) {\n try {\n await atCreate(T_ERRORS, {\n Workflow: \"GoodBeetle Bot\", Failed_Node: node, Error_Message: msg,\n Timestamp: new Date().toISOString(), Sender_Phone: sender, Raw_Message: raw,\n });\n } catch (_) { /* ignore */ }\n}\n\n// ============================================================================\n// GPT CATEGORY CLASSIFIER\n// ============================================================================\nasync function classify(query: string): Promise {\n const sys =\n \"You are a category classifier for a professional consultation marketplace. \" +\n \"Given a user's query, return ONLY one of these exact category names, nothing else: \" +\n \"Legal, Tax & GST, Startup & Compliance, Tech, Fitness, Nutrition, HR & Labour, \" +\n \"Marketing, Product, Astrology, Vastu. If the query does not match any category, \" +\n \"return exactly: NO_MATCH. Do not explain. Do not add punctuation.\";\n try {\n const r = await fetch(\"https://api.openai.com/v1/chat/completions\", {\n method: \"POST\",\n headers: { Authorization: `Bearer ${OPENAI_KEY}`, \"Content-Type\": \"application/json\" },\n body: JSON.stringify({\n model: \"gpt-4o-mini\", temperature: 0,\n messages: [{ role: \"system\", content: sys }, { role: \"user\", content: query }],\n }),\n });\n const d = await r.json();\n const out = (d.choices?.[0]?.message?.content || \"\").trim();\n return CATEGORIES.includes(out) ? out : \"NO_MATCH\";\n } catch (e: any) {\n console.error(\"classify error:\", e?.message);\n return \"NO_MATCH\";\n }\n}\n\n// ============================================================================\n// RAZORPAY PAYMENT\n// ============================================================================\nasync function createPaymentLink(\n buyerPhone: string, category: string, proName: string, amountPaise: number,\n): Promise {\n if (!RZP_KEY_ID || !RZP_SECRET) { console.log(\"Razorpay not configured — skipping\"); return null; }\n const auth = btoa(`${RZP_KEY_ID}:${RZP_SECRET}`);\n const phone = digits(buyerPhone);\n const payload = {\n amount: amountPaise,\n currency: \"INR\",\n description: `GoodBeetle: ${category} consultation with ${proName}`,\n customer: { contact: `+${phone}` },\n notify: { whatsapp: false, sms: false, email: false },\n reminder_enable: false,\n callback_url: `${PUBLIC_URL.replace(/\\/$/, \"\")}/payment?buyer_phone=${phone}`,\n callback_method: \"get\",\n notes: { buyer_phone: phone, category },\n };\n try {\n const r = await fetch(\"https://api.razorpay.com/v1/payment_links\", {\n method: \"POST\",\n headers: { Authorization: `Basic ${auth}`, \"Content-Type\": \"application/json\" },\n body: JSON.stringify(payload),\n });\n const d = await r.json();\n if (!r.ok) { console.error(\"Razorpay createPaymentLink FAILED:\", JSON.stringify(d)); return null; }\n console.log(\"Razorpay link created:\", d.short_url);\n return d.short_url || null;\n } catch (e: any) {\n console.error(\"Razorpay exception:\", e?.message);\n return null;\n }\n}\n\nasync function handlePaymentCallback(body: any) {\n const status = body?.razorpay_payment_link_status;\n const buyerPhone = digits(body?.buyer_phone || body?.notes?.buyer_phone || \"\");\n console.log(\"Payment callback status:\", status, \"buyer:\", buyerPhone);\n if (status !== \"paid\" || !buyerPhone) return;\n\n const user = await findUserByPhone(buyerPhone);\n if (!user) { console.error(\"Payment callback: user not found\", buyerPhone); return; }\n if (user.fields?.Bot_State !== \"AWAITING_PAYMENT\") {\n console.log(\"Payment callback: user not awaiting payment, ignoring\");\n return;\n }\n await atUpdate(T_USERS, user.id, { Bot_State: \"IN_SESSION\" }); // guard against double-trigger\n await sendText(buyerPhone, \"✅ Payment received! Connecting you with your expert now…\");\n await createSession(buyerPhone, user);\n}\n\n// ============================================================================\n// UI HELPERS (crisp copy + buttons everywhere)\n// ============================================================================\nconst CATEGORY_ROWS = [\n { id: \"legal\", title: \"⚖️ Legal\", description: \"Contracts, disputes, notices\" },\n { id: \"tax\", title: \"💰 Tax & GST\", description: \"Filing, GST, tax planning\" },\n { id: \"startup\", title: \"🚀 Startup & Compliance\", description: \"Incorporation, ROC, funding\" },\n { id: \"tech\", title: \"💻 Tech\", description: \"Software, websites, IT help\" },\n { id: \"fitness\", title: \"💪 Fitness\", description: \"Training & workout plans\" },\n { id: \"nutrition\", title: \"🍎 Nutrition\", description: \"Diet & meal guidance\" },\n { id: \"hr\", title: \"🏢 HR & Labour\", description: \"Hiring, payroll, labour law\" },\n { id: \"marketing\", title: \"📣 Marketing\", description: \"Branding, ads, growth\" },\n { id: \"product\", title: \"🛠️ Product\", description: \"Product & design advice\" },\n { id: \"astrology\", title: \"🔮 Astrology\", description: \"Readings & guidance\" },\n { id: \"vastu\", title: \"🏠 Vastu\", description: \"Space & layout advice\" },\n { id: \"other\", title: \"💬 Other\", description: \"Not sure? Describe it\" },\n];\n\nasync function showCategoryList(to: string, exclude: string[] = []) {\n const rows = CATEGORY_ROWS.filter((r) => !exclude.includes(CAT_BY_ID[r.id]));\n await sendList(to, \"GoodBeetle\", \"Pick what you need help with 👇\", \"Choose category\", rows);\n}\n\nasync function sendConsultantCard(to: string, pro: any, category: string) {\n const f = pro.fields;\n const rating = f[\"Rating\"] ? `⭐ ${f[\"Rating\"]}/5` : \"⭐ New\";\n const rate = f[\"Rate\"] ? `₹${f[\"Rate\"]}` : \"₹499\";\n const body =\n `*${f[\"Pro Name\"]}*\\n` +\n `${category} expert · ${rating}\\n` +\n `💵 ${rate} per session · ✅ Available now`;\n await sendButtons(to, body, [\n { id: \"confirm\", title: \"✅ Book expert\" },\n { id: \"change\", title: \"🔄 See another\" },\n { id: \"cancel\", title: \"✕ Cancel\" },\n ]);\n}\n\n// ============================================================================\n// MESSAGE PARSER\n// ============================================================================\ntype Msg = {\n sender: string; type: string; text: string; title: string;\n isInteractive: boolean; name: string;\n};\n\nfunction parse(body: any): Msg | null {\n try {\n const value = body?.entry?.[0]?.changes?.[0]?.value;\n const m = value?.messages?.[0];\n if (!m) return null;\n const sender = digits(m.from); // normalized\n const name = value?.contacts?.[0]?.profile?.name || \"\";\n if (m.type === \"text\") {\n return { sender, type: \"text\", text: (m.text?.body || \"\").trim(), title: \"\", isInteractive: false, name };\n }\n if (m.type === \"interactive\") {\n const btn = m.interactive?.button_reply;\n const list = m.interactive?.list_reply;\n const id = btn?.id || list?.id || \"\";\n const title = btn?.title || list?.title || \"\";\n return { sender, type: \"interactive\", text: id || title, title, isInteractive: true, name };\n }\n if (m.type === \"button\") {\n // Quick-reply button on an APPROVED TEMPLATE (e.g. professional_acceptance).\n // These arrive differently from the bot's own interactive buttons.\n const label = m.button?.text || m.button?.payload || \"\";\n return { sender, type: \"button\", text: label, title: label, isInteractive: true, name };\n }\n return { sender, type: m.type, text: \"\", title: \"\", isInteractive: false, name };\n } catch (_) {\n return null;\n }\n}\n\n// ============================================================================\n// UTILITIES\n// ============================================================================\nconst RELAY_CMDS = [\"CLOSE\", \"PAUSE\", \"RESUME\", \"HELP\"];\nconst isRelayCmd = (t: string) => RELAY_CMDS.includes(t.trim().toUpperCase());\nconst lc = (t: string) => t.trim().toLowerCase();\n\n// A message counts as \"end the session\" only if the WHOLE message is one of\n// these (equality, not substring) — so a real message like \"by month end\"\n// isn't mistaken for a close command.\nconst CLOSE_WORDS = new Set([\n \"close\", \"end\", \"done\", \"finish\", \"stop\", \"exit\", \"quit\", \"bye\",\n \"end session\", \"close session\", \"end chat\", \"close chat\", \"end the session\",\n \"band karo\", \"khatam\", \"khatam karo\", \"/end\", \"#end\",\n]);\nconst isCloseRequest = (t: string) => CLOSE_WORDS.has(lc(t));\n\nfunction selectionIntent(t: string): \"confirm\" | \"cancel\" | \"change\" | null {\n const s = lc(t);\n if ([\"yes\", \"ok\", \"okay\", \"confirm\", \"sure\", \"haan\", \"ha\", \"book\"].includes(s)) return \"confirm\";\n if ([\"no\", \"cancel\", \"nahi\", \"nope\"].includes(s)) return \"cancel\";\n if ([\"change\", \"other\", \"next\", \"aur\", \"different\", \"someone\"].includes(s)) return \"change\";\n return null;\n}\n\nfunction ratingFromText(t: string): number | null {\n const s = lc(t);\n if (/^[1-5]$/.test(s)) return parseInt(s, 10);\n if ([\"bad\", \"terrible\", \"worst\"].includes(s)) return 1;\n if ([\"good\", \"great\", \"excellent\", \"awesome\"].includes(s)) return 5;\n if ([\"okay\", \"fine\", \"average\"].includes(s)) return 3;\n return null;\n}\n\n// Simple in-memory dedupe (resets on cold start — fine for our purposes).\nconst recent = new Map();\n\n// ============================================================================\n// PRO PATH (relay + session controls)\n// ============================================================================\nasync function handleProPath(pro: any, msg: Msg) {\n const proPhone = msg.sender; // digits-only\n const session = await findSessionByProStatus(proPhone, \"Active\");\n const paused = await findSessionByProStatus(proPhone, \"Paused\");\n const cmd = msg.text.trim().toUpperCase();\n const titleLower = (msg.title || msg.text).trim().toLowerCase();\n // Letters-only key so template labels match regardless of apostrophe style,\n // spacing or punctuation: \"Let's Start\" / \"Let’s Start\" → \"letsstart\".\n const titleKey = (msg.title || msg.text).toLowerCase().replace(/[^a-z]/g, \"\");\n\n console.log(`handleProPath: cmd=\"${cmd}\" title=\"${titleLower}\" key=\"${titleKey}\" session=${session?.id} paused=${paused?.id}`);\n\n // --- Template button responses (from the professional_acceptance template) ---\n if (titleKey === \"letsstart\" && paused) {\n await atUpdate(T_SESSIONS, paused.id, { Status: \"Active\" });\n const cat = paused.fields[\"category\"] || \"\";\n const q = (paused.fields[\"query\"] || \"\").trim();\n const buyer = await getBuyerPhone(paused);\n let buyerName = \"your client\";\n if (buyer) {\n const bu = await findUserByPhone(buyer);\n buyerName = bu?.fields?.[\"Name\"] || \"your client\";\n }\n const context = q\n ? `📋 *What ${buyerName} needs:*\\n\"${q}\"`\n : `📋 _${buyerName} didn't add details — feel free to ask what they need._`;\n await sendButtons(msg.sender,\n `✅ You're connected${cat ? ` for a *${cat}* consultation` : \"\"}.\\n\\n${context}\\n\\nTap below to break the ice, or just start typing. Type *END* when you're done.`,\n [{ id: \"send_greeting\", title: \"👋 Say hi\" }, { id: \"CLOSE\", title: \"✅ End session\" }]);\n if (buyer) {\n await sendText(buyer, \"✅ Your expert has joined! Connecting you now…\\n\\n_(Type *END* anytime to finish.)_\");\n }\n return;\n }\n if (titleKey === \"notavailable\" && paused) {\n await atUpdate(T_SESSIONS, paused.id, { Status: \"Closed\" });\n await sendText(msg.sender, \"Got it — declined. You won't be disturbed for this request.\");\n const buyer = await getBuyerPhone(paused);\n if (buyer) {\n const buyerUser = await findUserByPhone(buyer);\n const cat = buyerUser?.fields?.Pending_Category || \"\";\n const altPro = cat ? await findPro(cat, proPhone) : null;\n if (altPro && buyerUser) {\n await atUpdate(T_USERS, buyerUser.id, {\n Bot_State: \"AWAITING_SELECTION\",\n Pending_Pro_ID: altPro.id,\n Pending_Pro_Phone: altPro.fields[\"Pro Phone\"],\n });\n await sendText(buyer, \"That expert just got busy. Here's another great option:\");\n await sendConsultantCard(buyer, altPro, cat);\n } else if (buyerUser) {\n await atUpdate(T_USERS, buyerUser.id, { Bot_State: \"POST_SESSION\", \"Active Session?\": false });\n await atCreate(T_WAITLIST, {\n User_Phone: buyer, Category: cat, Query: \"\", Status: \"Waiting\",\n Joined_At: new Date().toISOString(),\n });\n await sendButtons(buyer,\n \"All experts in this category are busy right now. We've added you to the waitlist and will ping you the moment one is free.\\n\\nIf you paid, a refund will be processed within 24 hours.\",\n [{ id: \"new_consult\", title: \"🔁 Try another\" }]);\n }\n }\n return;\n }\n if (titleKey === \"pleasewait\" && paused) {\n await sendText(msg.sender, \"⏸️ Okay, client is on hold. Send *RESUME* when you're ready.\");\n const buyer = await getBuyerPhone(paused);\n if (buyer) await sendText(buyer, \"⏸️ Your expert is finishing something and will be with you shortly.\");\n return;\n }\n\n if (cmd === \"HELP\") {\n await sendButtons(msg.sender, \"Session controls:\",\n [{ id: \"PAUSE\", title: \"⏸ Pause\" }, { id: \"RESUME\", title: \"▶️ Resume\" }, { id: \"CLOSE\", title: \"✅ End\" }]);\n return;\n }\n if (cmd === \"RESUME\" && paused) {\n await atUpdate(T_SESSIONS, paused.id, { Status: \"Active\" });\n await sendText(msg.sender, \"▶️ Session resumed.\");\n const buyer = await getBuyerPhone(paused);\n if (buyer) await sendText(buyer, \"▶️ Your expert is back. Go ahead!\");\n return;\n }\n\n if (!session && !paused) {\n await sendText(msg.sender, \"No active client session. You'll be notified the moment a client books you.\");\n return;\n }\n if (!session && paused) {\n await sendButtons(msg.sender, \"This session is on hold.\", [{ id: \"RESUME\", title: \"▶️ Resume\" }]);\n return;\n }\n\n const buyerPhone = await getBuyerPhone(session!);\n if (cmd === \"CLOSE\" || isCloseRequest(msg.text)) { await closeSession(session!, pro.fields[\"Pro Name\"], buyerPhone); return; }\n if (msg.text === \"send_greeting\") {\n const cat = session!.fields[\"category\"] || \"\";\n const proName = pro.fields[\"Pro Name\"] || \"your expert\";\n if (buyerPhone) {\n await sendText(buyerPhone,\n `👋 Hi, I'm *${proName}*${cat ? ` — happy to help with your ${cat} query` : \"\"}. What's going on?`);\n await logInteraction(session!.id, \"Pro -> Buyer\", `Hi, I'm ${proName}`);\n }\n await sendText(msg.sender, \"Sent ✅ Carry on chatting — type *END* when you're done.\");\n return;\n }\n if (cmd === \"PAUSE\") {\n await atUpdate(T_SESSIONS, session!.id, { Status: \"Paused\" });\n await sendButtons(msg.sender, \"⏸️ Session paused.\", [{ id: \"RESUME\", title: \"▶️ Resume\" }]);\n if (buyerPhone) await sendText(buyerPhone, \"⏸️ Your expert has paused briefly and will be back soon.\");\n return;\n }\n\n if (!msg.text) {\n await sendText(msg.sender, \"Only text can be relayed right now — please describe it in words or paste a link.\");\n return;\n }\n\n // --- RELAY: pro → buyer ---\n if (buyerPhone) {\n await sendText(buyerPhone, msg.text);\n await logInteraction(session!.id, \"Pro -> Buyer\", msg.text);\n } else {\n console.error(\"handleProPath: could not resolve buyer phone for session\", session!.id);\n await logError(\"relay_pro_to_buyer\", \"buyer phone missing\", proPhone, msg.text);\n await sendText(msg.sender, \"⚠️ Couldn't reach the client. Our team has been alerted.\");\n await sendText(ADMIN_PHONE, `⚠️ Relay failed: no buyer phone on session ${session!.id} (pro ${proPhone}).`);\n }\n}\n\n// ============================================================================\n// SESSION CLOSE + FEEDBACK\n// ============================================================================\nasync function closeSession(session: any, proName: string, buyerPhone: string | null) {\n await atUpdate(T_SESSIONS, session.id, { Status: \"Closed\" });\n const proPhone = session.fields[\"Pro Phone\"];\n if (proPhone) await sendText(proPhone, `Session closed ✅\\n\\nThanks for your time, ${proName}!`);\n if (buyerPhone) {\n const user = await findUserByPhone(buyerPhone);\n if (user) await atUpdate(T_USERS, user.id, { \"Active Session?\": false, Bot_State: \"AWAITING_FEEDBACK\" });\n await sendButtons(buyerPhone,\n `Your session with *${proName}* has ended.\\n\\nHow would you rate it?`,\n [\n { id: \"rate_1\", title: \"⭐ Poor\" },\n { id: \"rate_3\", title: \"⭐⭐⭐ Okay\" },\n { id: \"rate_5\", title: \"⭐⭐⭐⭐⭐ Great\" },\n ]);\n }\n}\n\n// Cancel a session the pro never accepted (buyer bailed while waiting).\nasync function cancelPendingSession(sender: string, user: any, session: any) {\n await atUpdate(T_SESSIONS, session.id, { Status: \"Closed\" });\n await atUpdate(T_USERS, user.id, {\n \"Active Session?\": false, Bot_State: \"AWAITING_QUERY\",\n Pending_Pro_ID: \"\", Pending_Pro_Phone: \"\", Pending_Category: \"\", Pending_Query: \"\",\n });\n // Let the pro know the request was withdrawn (harmless if it never reached them).\n const proPhone = session.fields[\"Pro Phone\"];\n if (proPhone) await sendText(proPhone, \"The client withdrew this request before it started. No action needed.\");\n await sendButtons(sender, \"Cancelled — you're not connected to anyone. Start a new request whenever you like.\",\n [{ id: \"new_consult\", title: \"🔁 New request\" }]);\n}\n\n// ============================================================================\n// MAIN MESSAGE HANDLER\n// ============================================================================\nasync function handleMessage(body: any) {\n const msg = parse(body);\n if (!msg) { console.log(\"No parseable message — likely a status update, skipping\"); return; }\n\n // Dedupe identical sender+text within 5s.\n const key = msg.sender + \"|\" + msg.text;\n const now = Date.now();\n if (recent.has(key) && now - (recent.get(key) || 0) < 5000) { console.log(\"Deduped:\", key); return; }\n recent.set(key, now);\n if (recent.size > 500) recent.clear();\n\n const sender = msg.sender;\n console.log(`MSG from ${sender}: type=${msg.type} text=\"${msg.text}\" title=\"${msg.title}\"`);\n\n try {\n const pro = await findProByPhone(sender);\n let user = await findUserByPhone(sender);\n const state: string = user?.fields?.Bot_State || \"\";\n\n // ── Pro routing ──────────────────────────────────────────────────────\n if (pro) {\n const hasActiveSession = await findActiveOrPausedByPro(sender);\n if (hasActiveSession || isRelayCmd(msg.text)) {\n return await handleProPath(pro, msg);\n }\n if (state === \"PRO_OR_BUYER_PENDING\") {\n if (msg.text === \"as_pro\") {\n if (user) await atUpdate(T_USERS, user.id, { Bot_State: \"\" });\n return await handleProPath(pro, msg);\n }\n if (msg.text === \"as_buyer\") {\n if (!user) user = await atCreate(T_USERS, { \"Phone Number\": sender, Name: msg.name, Bot_State: \"AWAITING_QUERY\" });\n else await atUpdate(T_USERS, user.id, { Bot_State: \"AWAITING_QUERY\" });\n const own = pro.fields[\"Category (from Specialization)\"] || [];\n await showCategoryList(sender, own);\n return;\n }\n await sendButtons(sender,\n \"Quick check — how are you using GoodBeetle right now?\",\n [{ id: \"as_pro\", title: \"👔 I have a client\" }, { id: \"as_buyer\", title: \"🙋 I need advice\" }]);\n return;\n }\n // Pro with no active session and not in a flow — ask intent.\n if (!user) user = await atCreate(T_USERS, { \"Phone Number\": sender, Name: msg.name, Bot_State: \"PRO_OR_BUYER_PENDING\" });\n else await atUpdate(T_USERS, user.id, { Bot_State: \"PRO_OR_BUYER_PENDING\" });\n await sendButtons(sender,\n \"👋 Hey! How are you using GoodBeetle right now?\",\n [{ id: \"as_pro\", title: \"👔 I have a client\" }, { id: \"as_buyer\", title: \"🙋 I need advice\" }]);\n return;\n }\n\n // ── Global text commands ─────────────────────────────────────────────\n const low = lc(msg.text);\n if (!msg.isInteractive && [\"menu\", \"start\", \"hi\", \"hello\", \"hey\"].includes(low)) {\n return await reprompt(sender, user, state, msg.name);\n }\n if (!msg.isInteractive && low === \"help\") {\n return await contextHelp(sender, state);\n }\n\n // ── New buyer (with loud-failure handling — fixes the welcome loop) ───\n if (!user) {\n const name = msg.name || \"there\";\n user = await atCreate(T_USERS, { \"Phone Number\": sender, Name: msg.name, Bot_State: \"AWAITING_QUERY\" });\n if (!user) {\n // Insert genuinely failed (schema mismatch / wrong key). Don't loop silently.\n console.error(\"New-buyer create FAILED for\", sender);\n await logError(\"create_user\", \"insert returned null\", sender, JSON.stringify(body).slice(0, 500));\n await sendText(sender, \"Sorry, something went wrong on our side. Please try again in a moment 🙏\");\n await sendText(ADMIN_PHONE, `⚠️ Could not create user ${sender}. Check Supabase schema / service_role key.`);\n return;\n }\n await sendText(sender, `👋 Welcome to *GoodBeetle*, ${name}!\\n\\nVerified experts, on-demand, right here on WhatsApp.`);\n // If their very first message already says what they want, act on it now\n // instead of just re-showing the menu.\n if (msg.isInteractive || (msg.type === \"text\" && msg.text)) {\n return await phaseAwaitingQuery(sender, user, msg, pro);\n }\n await showCategoryList(sender);\n return;\n }\n\n // ── State router ─────────────────────────────────────────────────────\n switch (state) {\n case \"\":\n case \"AWAITING_QUERY\": return await phaseAwaitingQuery(sender, user, msg, pro);\n case \"AWAITING_DETAILS\": return await phaseAwaitingDetails(sender, user, msg, pro);\n case \"AWAITING_SELECTION\": return await phaseSelection(sender, user, msg);\n case \"AWAITING_PAYMENT\": return await phaseAwaitingPayment(sender, user, msg);\n case \"IN_SESSION\": return await phaseInSession(sender, user, msg);\n case \"AWAITING_FEEDBACK\": return await phaseFeedback(sender, user, msg);\n case \"GRIEVANCE\": return await phaseGrievance(sender, user, msg);\n case \"POST_SESSION\": return await phasePostSession(sender, user, msg);\n default:\n await atUpdate(T_USERS, user.id, { Bot_State: \"AWAITING_QUERY\" });\n await showCategoryList(sender);\n return;\n }\n } catch (e: any) {\n console.error(\"handleMessage outer catch:\", e?.message, e?.stack);\n await logError(\"handleMessage\", String(e?.message || e), sender, JSON.stringify(body).slice(0, 1000));\n }\n}\n\n// ============================================================================\n// STATE HANDLERS\n// ============================================================================\nasync function phaseAwaitingQuery(sender: string, user: any, msg: Msg, pro: any) {\n if (msg.isInteractive) {\n if (msg.text === \"other\") {\n await atUpdate(T_USERS, user.id, { Pending_Category: \"UNKNOWN\", Bot_State: \"AWAITING_QUERY\" });\n await sendText(sender, \"No problem! Tell me in a sentence what you need, and I'll find the right expert.\");\n return;\n }\n const category = CAT_BY_ID[msg.text];\n if (category) {\n // A pro can't pick their own category when acting as a buyer.\n if (pro) {\n const own: string[] = (pro.fields[\"Category (from Specialization)\"] || [])\n .map((c: any) => (typeof c === \"string\" ? c : c?.name || \"\"));\n if (own.includes(category)) {\n await sendText(sender, `You're a ${category} expert yourself! Pick a different category for your own query.`);\n await showCategoryList(sender, own);\n return;\n }\n }\n await atUpdate(T_USERS, user.id, {\n Pending_Category: category, Bot_State: \"AWAITING_DETAILS\", Pending_Query: \"\",\n });\n await sendText(sender,\n `Got it — *${category}*. In one line, what do you need help with?\\n\\n_(We share this with your expert so they can prepare.)_`);\n return;\n }\n if ([\"wl_join\", \"wl_diff\", \"wl_never\"].includes(msg.text)) {\n return await unknownWaitlistChoice(sender, user, msg.text);\n }\n }\n\n // Second attempt after \"Other\" → free text.\n if (user.fields?.Pending_Category === \"UNKNOWN\" && msg.type === \"text\" && msg.text) {\n const cat2 = await classify(msg.text);\n if (cat2 !== \"NO_MATCH\") {\n await atUpdate(T_USERS, user.id, { Pending_Category: cat2, Pending_Query: msg.text });\n return await tryFindPro(sender, user, cat2, pro, msg.text);\n }\n await atUpdate(T_USERS, user.id, { Pending_Pro_ID: msg.text }); // stash description\n await sendButtons(sender,\n \"We don't cover that category *yet* — but we're growing fast. Want us to notify you?\",\n [\n { id: \"wl_join\", title: \"✅ Notify me\" },\n { id: \"wl_diff\", title: \"🔄 Pick another\" },\n { id: \"wl_never\", title: \"✕ Never mind\" },\n ]);\n return;\n }\n\n // Free-text query.\n if (msg.type === \"text\" && msg.text) {\n const cat = await classify(msg.text);\n if (cat === \"NO_MATCH\") {\n await sendText(sender, \"I'm not sure which category fits. Pick one below 👇\");\n await showCategoryList(sender);\n return;\n }\n await atUpdate(T_USERS, user.id, { Pending_Category: cat, Pending_Query: msg.text });\n return await tryFindPro(sender, user, cat, pro, msg.text);\n }\n\n await showCategoryList(sender);\n}\n\n// Buyer describes their need (one line) after tapping a category, then we match.\nasync function phaseAwaitingDetails(sender: string, user: any, msg: Msg, pro: any) {\n const category = user.fields?.Pending_Category;\n if (!category || category === \"UNKNOWN\") {\n await atUpdate(T_USERS, user.id, { Bot_State: \"AWAITING_QUERY\" });\n await showCategoryList(sender);\n return;\n }\n // Whatever they typed becomes the query the expert will see (blank is OK).\n const query = msg.type === \"text\" && msg.text ? msg.text.trim() : \"\";\n await atUpdate(T_USERS, user.id, { Pending_Query: query });\n return await tryFindPro(sender, user, category, pro, query || undefined);\n}\n\nasync function unknownWaitlistChoice(sender: string, user: any, choice: string) {\n if (choice === \"wl_join\") {\n const desc = user.fields?.Pending_Pro_ID || \"your request\";\n await atCreate(T_WAITLIST, {\n User_Phone: sender, Category: \"UNKNOWN\", Query: desc, Status: \"Waiting\",\n Joined_At: new Date().toISOString(),\n });\n await atUpdate(T_USERS, user.id, { Bot_State: \"POST_SESSION\", Pending_Category: \"\", Pending_Pro_ID: \"\" });\n await sendText(sender, \"Done ✅ You're on the list — we'll WhatsApp you the moment an expert is available.\");\n return;\n }\n if (choice === \"wl_diff\") {\n await atUpdate(T_USERS, user.id, { Pending_Category: \"\", Pending_Pro_ID: \"\" });\n await showCategoryList(sender);\n return;\n }\n await atUpdate(T_USERS, user.id, { Bot_State: \"AWAITING_QUERY\", Pending_Category: \"\", Pending_Pro_ID: \"\" });\n await sendText(sender, \"No problem — come back anytime 👋\");\n}\n\nasync function tryFindPro(sender: string, user: any, category: string, pro: any, queryText?: string) {\n // A pro can't be matched to their own category.\n if (pro) {\n const own: string[] = (pro.fields[\"Category (from Specialization)\"] || [])\n .map((c: any) => (typeof c === \"string\" ? c : c?.name || \"\"));\n if (own.includes(category)) {\n await sendText(sender, `You're a ${category} expert yourself! Pick a different category for your own query.`);\n await showCategoryList(sender, own);\n return;\n }\n }\n if (queryText) await atUpdate(T_USERS, user.id, { Pending_Category: category });\n\n const found = await findPro(category);\n if (!found) {\n await atUpdate(T_USERS, user.id, { Pending_Category: category, Pending_Pro_Phone: \"WAIT\" });\n await sendButtons(sender,\n `All our ${category} experts are with clients right now. Want us to ping you the moment one is free?`,\n [{ id: \"wl_join2\", title: \"✅ Join waitlist\" }, { id: \"cancel\", title: \"✕ Cancel\" }]);\n return;\n }\n await atUpdate(T_USERS, user.id, {\n Bot_State: \"AWAITING_SELECTION\",\n Pending_Pro_ID: found.id,\n Pending_Pro_Phone: found.fields[\"Pro Phone\"],\n Pending_Category: category,\n });\n await sendText(sender, `Great — found you a ${category} expert 👇`);\n await sendConsultantCard(sender, found, category);\n}\n\nasync function phaseSelection(sender: string, user: any, msg: Msg) {\n const f = user.fields;\n const action: string | null = msg.isInteractive ? msg.text : selectionIntent(msg.text);\n\n if (action === \"confirm\" || action === \"keep\") return await initiatePayment(sender, user);\n\n if (action === \"change\") {\n const cat = f.Pending_Category;\n const other = await findPro(cat, f.Pending_Pro_Phone);\n if (other) {\n await atUpdate(T_USERS, user.id, {\n Pending_Pro_ID: other.id, Pending_Pro_Phone: other.fields[\"Pro Phone\"],\n });\n await sendConsultantCard(sender, other, cat);\n return;\n }\n await sendButtons(sender, `No other ${cat} expert is free right now.`, [\n { id: \"keep\", title: \"✅ Keep this one\" },\n { id: \"wl_join2\", title: \"📋 Join waitlist\" },\n { id: \"cancel\", title: \"✕ Cancel\" },\n ]);\n return;\n }\n if (action === \"wl_join2\") {\n await atCreate(T_WAITLIST, {\n User_Phone: sender, Category: f.Pending_Category, Query: \"\", Status: \"Waiting\",\n Joined_At: new Date().toISOString(),\n });\n await atUpdate(T_USERS, user.id, {\n Bot_State: \"POST_SESSION\", Pending_Pro_ID: \"\", Pending_Pro_Phone: \"\", Pending_Category: \"\",\n });\n await sendText(sender, `You're on the waitlist ✅ We'll reach out the moment a ${f.Pending_Category} expert is free.`);\n return;\n }\n if (action === \"cancel\") {\n await atUpdate(T_USERS, user.id, {\n Bot_State: \"AWAITING_QUERY\", Pending_Pro_ID: \"\", Pending_Pro_Phone: \"\", Pending_Category: \"\",\n });\n await sendButtons(sender, \"No problem 👋 Start a new search whenever you like.\", [{ id: \"new_consult\", title: \"🔁 New search\" }]);\n return;\n }\n // Unrecognised — re-show the card buttons.\n await sendButtons(sender, \"Would you like to book this expert?\", [\n { id: \"confirm\", title: \"✅ Book expert\" },\n { id: \"change\", title: \"🔄 See another\" },\n { id: \"cancel\", title: \"✕ Cancel\" },\n ]);\n}\n\n// ── Payment gate ────────────────────────────────────────────────────────────\nasync function initiatePayment(sender: string, user: any) {\n const f = user.fields;\n const proPhone = f.Pending_Pro_Phone;\n const category = f.Pending_Category;\n const pro = await findProByPhone(proPhone);\n const proName = pro?.fields?.[\"Pro Name\"] || \"your expert\";\n const rateRaw = pro?.fields?.[\"Rate\"];\n const amountPaise = rateRaw ? Math.round(parseFloat(rateRaw) * 100) : SESSION_FEE_PAISE;\n const amountRs = amountPaise / 100;\n\n if (!RZP_KEY_ID) { console.log(\"No Razorpay — skipping payment gate\"); await createSession(sender, user); return; }\n\n const link = await createPaymentLink(sender, category, proName, amountPaise);\n if (!link) { console.log(\"Payment link failed — proceeding without payment\"); await createSession(sender, user); return; }\n\n await atUpdate(T_USERS, user.id, {\n Bot_State: \"AWAITING_PAYMENT\",\n Pending_Pro_ID: f.Pending_Pro_ID, Pending_Pro_Phone: proPhone, Pending_Category: category,\n });\n await sendButtons(sender,\n `Almost done! Pay *₹${amountRs}* to confirm your session with *${proName}*.\\n\\n👉 ${link}\\n\\n_Secure payment via Razorpay. We'll connect you the instant it clears._`,\n [{ id: \"cancel\", title: \"✕ Cancel booking\" }]);\n}\n\nasync function phaseAwaitingPayment(sender: string, user: any, msg: Msg) {\n const low = lc(msg.text);\n if ([\"cancel\", \"nahi\", \"no\", \"abort\"].includes(low) || msg.text === \"cancel\") {\n await atUpdate(T_USERS, user.id, {\n Bot_State: \"AWAITING_QUERY\", Pending_Pro_ID: \"\", Pending_Pro_Phone: \"\", Pending_Category: \"\",\n });\n await sendButtons(sender, \"Booking cancelled. No charge made 👋\", [{ id: \"new_consult\", title: \"🔁 New search\" }]);\n return;\n }\n await sendButtons(sender,\n \"⏳ Waiting for your payment to clear. You'll be connected automatically once it does.\",\n [{ id: \"cancel\", title: \"✕ Cancel booking\" }]);\n}\n\n// ── Session creation ─────────────────────────────────────────────────────────\nasync function createSession(sender: string, user: any) {\n const f = user.fields;\n const proPhone = f.Pending_Pro_Phone;\n const proId = f.Pending_Pro_ID;\n const category = f.Pending_Category;\n const query = f.Pending_Query || \"\";\n const pro = await findProByPhone(proPhone);\n const proName = pro?.fields?.[\"Pro Name\"] || \"your expert\";\n\n // Session starts Paused until the pro accepts. buyer_phone denormalized (digits).\n const sessionRec = await atCreate(T_SESSIONS, {\n Users: [user.id],\n Professionals: [proId],\n Status: \"Paused\",\n \"Pro Phone\": digits(proPhone),\n buyer_phone: digits(sender),\n category: category,\n query: query,\n });\n if (!sessionRec) {\n await logError(\"create_session\", \"insert returned null\", sender, \"\");\n await sendText(sender, \"Sorry, we hit a snag connecting you. Our team has been alerted 🙏\");\n await sendText(ADMIN_PHONE, `⚠️ Session create failed for buyer ${sender} / pro ${proPhone}.`);\n return;\n }\n\n await atUpdate(T_USERS, user.id, {\n \"Active Session?\": true, Bot_State: \"IN_SESSION\",\n Pending_Pro_ID: \"\", Pending_Pro_Phone: \"\", Pending_Category: \"\", Pending_Query: \"\",\n });\n await sendText(sender, `⏳ *${proName}* has been notified and will confirm shortly — hang tight!`);\n\n const ok = await sendProTemplate(proPhone, category);\n if (!ok) {\n await logError(\"notify_pro\", \"Template send to pro failed\", digits(proPhone), \"\");\n await sendText(ADMIN_PHONE, `⚠️ Failed to notify ${proName} (${proPhone}) for ${category}. Buyer: ${sender}`);\n await sendText(sender, \"We're having trouble reaching your expert. Our team will connect you manually — sorry for the wait!\");\n }\n}\n\n// ── IN_SESSION (relay buyer → pro) ────────────────────────────────────────────\nasync function phaseInSession(sender: string, user: any, msg: Msg) {\n const session = await findSessionByUserStatus(user.id, \"Active\");\n const paused = await findSessionByUserStatus(user.id, \"Paused\");\n\n if (paused && !session) {\n // Pro hasn't accepted yet. The buyer must be able to bail out while waiting.\n if (msg.isInteractive && (msg.text === \"CLOSE\" || msg.text === \"end_yes\")) {\n return await cancelPendingSession(sender, user, paused);\n }\n if (msg.isInteractive && msg.text === \"end_no\") {\n await sendText(sender, \"👍 Still holding your spot — your expert will join shortly.\");\n return;\n }\n if (isCloseRequest(msg.text)) {\n await sendButtons(sender, \"Your expert hasn't joined yet. Cancel this request?\", [\n { id: \"end_yes\", title: \"✅ Yes, cancel\" },\n { id: \"end_no\", title: \"↩️ Keep waiting\" },\n ]);\n return;\n }\n await sendButtons(sender, \"⏸️ Your expert is getting ready and will join shortly — please hold on.\", [\n { id: \"CLOSE\", title: \"✕ Cancel request\" },\n ]);\n return;\n }\n if (!session) {\n await atUpdate(T_USERS, user.id, { Bot_State: \"POST_SESSION\", \"Active Session?\": false });\n await sendText(sender, \"Your session has ended. Hope it helped!\");\n return;\n }\n\n const proPhone = session.fields[\"Pro Phone\"];\n\n if (msg.isInteractive) {\n if (msg.text === \"end_yes\") {\n const proRec = await findProByPhone(proPhone);\n await closeSession(session, proRec?.fields?.[\"Pro Name\"] || \"your expert\", sender);\n return;\n }\n if (msg.text === \"end_no\") { await sendText(sender, \"👍 Continuing your session.\"); return; }\n }\n\n if (!msg.text) {\n await sendText(sender, \"Only text can be relayed right now — describe it in words (links are fine).\");\n return;\n }\n if (isCloseRequest(msg.text)) {\n await sendButtons(sender, \"End this session?\", [\n { id: \"end_yes\", title: \"✅ Yes, end\" },\n { id: \"end_no\", title: \"↩️ No, continue\" },\n ]);\n return;\n }\n\n if (!proPhone) {\n await sendText(sender, \"⚠️ Couldn't reach your expert. Please contact support.\");\n return;\n }\n await sendText(proPhone, msg.text);\n await logInteraction(session.id, \"Buyer -> Pro\", msg.text);\n}\n\n// ── FEEDBACK ──────────────────────────────────────────────────────────────────\nasync function phaseFeedback(sender: string, user: any, msg: Msg) {\n let rating: number | null = null;\n if (msg.isInteractive && msg.text.startsWith(\"rate_\")) rating = parseInt(msg.text.split(\"_\")[1], 10);\n else rating = ratingFromText(msg.text);\n\n if (!rating) {\n await sendButtons(sender, \"How would you rate your session?\", [\n { id: \"rate_1\", title: \"⭐ Poor\" },\n { id: \"rate_3\", title: \"⭐⭐⭐ Okay\" },\n { id: \"rate_5\", title: \"⭐⭐⭐⭐⭐ Great\" },\n ]);\n return;\n }\n\n const session = await findSessionByUserStatus(user.id, \"Closed\");\n if (session) {\n await atUpdate(T_SESSIONS, session.id, { Rating: rating });\n const pro = await findProByPhone(session.fields[\"Pro Phone\"]);\n if (pro) {\n const old = pro.fields[\"Rating\"] || rating;\n await atUpdate(T_PROS, pro.id, { Rating: Math.round(((old + rating) / 2) * 10) / 10 });\n }\n }\n\n if (rating >= 3) {\n await atUpdate(T_USERS, user.id, { Bot_State: \"POST_SESSION\" });\n await sendText(sender, rating >= 4 ? \"🎉 Glad it helped — thanks for the great rating!\" : \"Thanks for the feedback 🙏\");\n await phasePostSession(sender, user, msg, true);\n return;\n }\n // Low rating → grievance.\n await atUpdate(T_USERS, user.id, { Bot_State: \"GRIEVANCE\" });\n await sendText(sender, \"Really sorry about that 😔 What went wrong? We take this seriously and will look into it.\");\n}\n\n// ── GRIEVANCE ──────────────────────────────────────────────────────────────────\nasync function phaseGrievance(sender: string, user: any, msg: Msg) {\n const complaint = msg.text || \"(no detail provided)\";\n const session = await findSessionByUserStatus(user.id, \"Closed\");\n let proName = \"an expert\";\n if (session) {\n const pro = await findProByPhone(session.fields[\"Pro Phone\"]);\n proName = pro?.fields?.[\"Pro Name\"] || proName;\n }\n await sendText(ADMIN_PHONE, `⚠️ Low-rating complaint\\nBuyer: ${sender}\\nExpert: ${proName}\\n\\n\"${complaint}\"`);\n await atUpdate(T_USERS, user.id, { Bot_State: \"POST_SESSION\" });\n await sendText(sender, \"Thank you — we've logged this and our team will follow up. Quality matters to us.\");\n await phasePostSession(sender, user, msg, true);\n}\n\n// ── POST_SESSION ────────────────────────────────────────────────────────────────\nasync function phasePostSession(sender: string, user: any, msg: Msg, justArrived = false) {\n if (!justArrived && msg.isInteractive) {\n if (msg.text === \"new_consult\") {\n await atUpdate(T_USERS, user.id, {\n Bot_State: \"AWAITING_QUERY\", Pending_Pro_ID: \"\", Pending_Pro_Phone: \"\", Pending_Category: \"\",\n });\n await showCategoryList(sender);\n return;\n }\n if (msg.text === \"support\") {\n await sendText(ADMIN_PHONE, `💬 Support request from ${sender}.`);\n await sendText(sender, \"Our team will reach out shortly 🙏\");\n return;\n }\n if (msg.text === \"refer\") {\n await sendText(sender, \"❤️ Thank you! Share GoodBeetle with a friend:\\nhttps://wa.me/919354052769?text=Hi%20GoodBeetle\");\n return;\n }\n }\n if (justArrived) {\n await sendButtons(sender, \"What next?\", [\n { id: \"new_consult\", title: \"🔁 New session\" },\n { id: \"refer\", title: \"🤝 Refer a friend\" },\n ]);\n }\n}\n\n// ============================================================================\n// GREETING / HELP\n// ============================================================================\nasync function reprompt(sender: string, user: any | null, state: string, name = \"\") {\n if (!user) {\n // First contact via a greeting: create the user now so their next tap is\n // handled as a real selection (prevents the \"welcome twice\" double-step).\n await atCreate(T_USERS, { \"Phone Number\": sender, Name: name, Bot_State: \"AWAITING_QUERY\" });\n await sendText(sender, \"👋 Welcome to *GoodBeetle* — verified experts, on-demand on WhatsApp.\");\n await showCategoryList(sender);\n return;\n }\n switch (state) {\n case \"IN_SESSION\": {\n const session = await findSessionByUserStatus(user.id, \"Active\");\n const paused = await findSessionByUserStatus(user.id, \"Paused\");\n if (!session && paused) {\n // Pro hasn't accepted yet — offer a way out instead of pretending we're connected.\n await sendButtons(sender, \"⏳ Your expert hasn't joined yet — please hold on a moment.\",\n [{ id: \"CLOSE\", title: \"✕ Cancel request\" }]);\n return;\n }\n if (!session && !paused) {\n // Stale state with no session at all — recover gracefully.\n await atUpdate(T_USERS, user.id, { Bot_State: \"AWAITING_QUERY\", \"Active Session?\": false });\n await sendText(sender, \"👋 What do you need help with today?\");\n await showCategoryList(sender);\n return;\n }\n const pro = await findProByPhone(session!.fields[\"Pro Phone\"]);\n const proName = pro?.fields?.[\"Pro Name\"] || \"your expert\";\n await sendButtons(sender, `You're chatting with *${proName}*. Just type to send a message.`,\n [{ id: \"CLOSE\", title: \"✅ End session\" }]);\n return;\n }\n case \"AWAITING_DETAILS\": {\n const cat = user.fields?.Pending_Category;\n await sendText(sender, cat\n ? `You picked *${cat}*. In one line, what do you need help with?`\n : \"In one line, what do you need help with?\");\n return;\n }\n case \"AWAITING_SELECTION\":\n await sendButtons(sender, \"You were choosing an expert. Still interested?\", [\n { id: \"confirm\", title: \"✅ Book expert\" },\n { id: \"change\", title: \"🔄 See another\" },\n { id: \"cancel\", title: \"✕ Cancel\" },\n ]);\n return;\n case \"AWAITING_PAYMENT\":\n await sendButtons(sender, \"⏳ You have a pending payment to finish your booking.\", [{ id: \"cancel\", title: \"✕ Cancel booking\" }]);\n return;\n case \"AWAITING_FEEDBACK\":\n await sendButtons(sender, \"How was your session?\", [\n { id: \"rate_1\", title: \"⭐ Poor\" },\n { id: \"rate_3\", title: \"⭐⭐⭐ Okay\" },\n { id: \"rate_5\", title: \"⭐⭐⭐⭐⭐ Great\" },\n ]);\n return;\n case \"POST_SESSION\":\n await sendButtons(sender, \"What would you like to do?\", [\n { id: \"new_consult\", title: \"🔁 New session\" },\n { id: \"refer\", title: \"🤝 Refer a friend\" },\n ]);\n return;\n default:\n await sendText(sender, \"👋 Hi! What do you need help with?\");\n await showCategoryList(sender);\n return;\n }\n}\n\nasync function contextHelp(sender: string, state: string) {\n const msgs: Record = {\n \"\": \"Pick a category from the menu, or describe what you need.\",\n AWAITING_QUERY: \"Pick a category from the menu, or type what you need and I'll match you.\",\n AWAITING_DETAILS: \"Type one line describing what you need, and I'll find your expert.\",\n AWAITING_SELECTION: \"Tap *Book expert* to confirm, *See another* to browse, or *Cancel* to start over.\",\n AWAITING_PAYMENT: \"Finish the payment to confirm, or tap *Cancel booking* to abort.\",\n IN_SESSION: \"Type to chat with your expert. Tap *End session* when you're done.\",\n AWAITING_FEEDBACK: \"Tap a rating (1–5) to finish.\",\n POST_SESSION: \"Tap *New session* to start another consultation.\",\n };\n await sendText(sender, msgs[state] || msgs[\"\"]);\n}","// ============================================================================\n// GoodBeetle WhatsApp Consultation Bot — VAL TOWN (HTTP val)\n// DATABASE: Supabase (Postgres). Razorpay payments built in.\n// ----------------------------------------------------------------------------\n// Create this as an *HTTP* val. Val Town gives it a public URL like:\n// https://--goodbeetle_bot.web.val.run\n// Paste that URL into Meta as the webhook Callback URL.\n//\n// SECRETS — set in Val Town → Settings → Environment Variables:\n// WHATSAPP_TOKEN = Meta permanent System User token\n// SUPABASE_URL = https://.supabase.co\n// SUPABASE_SERVICE_KEY = Supabase **service_role** key (NOT the anon key!)\n// OPENAI_KEY = OpenAI API key\n// META_VERIFY_TOKEN = any word YOU choose (type the same word in Meta)\n// PUBLIC_URL = this val's own URL (for Razorpay callback). Optional.\n// RAZORPAY_KEY_ID = Razorpay Key ID (optional — payments skip if unset)\n// RAZORPAY_KEY_SECRET = Razorpay Key Secret (optional)\n//\n// IMPORTANT: run the schema in supabase_schema.sql once before going live.\n// ============================================================================\n\nimport { createClient } from \"npm:@supabase/supabase-js@2\";\n\n// ---- Secrets ---------------------------------------------------------------\nconst WA_TOKEN = Deno.env.get(\"WHATSAPP_TOKEN\")!;\nconst SUPABASE_URL = Deno.env.get(\"SUPABASE_URL\")!;\nconst SUPABASE_SERVICE_KEY = Deno.env.get(\"SUPABASE_SERVICE_KEY\")!;\nconst OPENAI_KEY = Deno.env.get(\"OPENAI_KEY\")!;\nconst VERIFY_TOKEN = Deno.env.get(\"META_VERIFY_TOKEN\")!;\nconst RZP_KEY_ID = Deno.env.get(\"RAZORPAY_KEY_ID\") || \"\";\nconst RZP_SECRET = Deno.env.get(\"RAZORPAY_KEY_SECRET\") || \"\";\nconst RZP_WEBHOOK_SECRET = Deno.env.get(\"RAZORPAY_WEBHOOK_SECRET\") || \"\";\nconst PUBLIC_URL =\n Deno.env.get(\"PUBLIC_URL\") ||\n \"https://goodbeetle--74eb91e25ec511f1b6111607ee4eb77e.web.val.run\";\n\n// ---- Supabase client (service_role bypasses RLS — keep server-side only) ----\nconst sb = createClient(SUPABASE_URL, SUPABASE_SERVICE_KEY, {\n auth: { persistSession: false },\n});\n\n// ---- Config ----------------------------------------------------------------\nconst PHONE_NUMBER_ID = \"980400758497769\";\nconst WA_URL = `https://graph.facebook.com/v18.0/${PHONE_NUMBER_ID}/messages`;\nconst ADMIN_PHONE = \"919354052769\";\nconst SESSION_FEE_PAISE = 49900; // ₹499 default (overridden per-pro by \"Rate\")\n\n// Logical table keys (used as keys into TABLE_MAP below).\nconst T_USERS = \"users\";\nconst T_PROS = \"professionals\";\nconst T_SESSIONS = \"sessions\";\nconst T_WAITLIST = \"waitlist\";\nconst T_LOGS = \"interaction_logs\";\nconst T_ERRORS = \"error_logs\";\n\nconst CATEGORIES = [\n \"Legal\", \"Tax & GST\", \"Startup & Compliance\", \"Tech\", \"Fitness\",\n \"Nutrition\", \"HR & Labour\", \"Marketing\", \"Product\", \"Astrology\", \"Vastu\",\n];\nconst CAT_BY_ID: Record = {\n legal: \"Legal\", tax: \"Tax & GST\", startup: \"Startup & Compliance\",\n tech: \"Tech\", fitness: \"Fitness\", nutrition: \"Nutrition\",\n hr: \"HR & Labour\", marketing: \"Marketing\", product: \"Product\",\n astrology: \"Astrology\", vastu: \"Vastu\",\n};\n\n// ============================================================================\n// PHONE NORMALIZATION — the single most important fix.\n// Everything (store, lookup, send) uses digits-only so a number always\n// matches itself regardless of \"+\", spaces, or dashes.\n// ============================================================================\nconst digits = (p?: string | null): string => (p || \"\").replace(/[^0-9]/g, \"\");\n\n// Builds a Supabase \".or()\" filter that matches a phone stored either as\n// \"919...\" or \"+919...\" — so legacy rows (with \"+\") still resolve.\nconst phoneOr = (col: string, phone: string): string => {\n const d = digits(phone);\n return `${col}.eq.${d},${col}.eq.+${d}`;\n};\n\n// ============================================================================\n// HTTP ENTRYPOINT\n// ============================================================================\nexport default async function (req: Request): Promise {\n const url = new URL(req.url);\n\n // Meta webhook verification (GET) — also serves Razorpay GET callback.\n if (req.method === \"GET\") {\n if (url.pathname.includes(\"/payment\")) {\n try {\n await handlePaymentCallback({\n razorpay_payment_link_id: url.searchParams.get(\"razorpay_payment_link_id\"),\n razorpay_payment_link_status: url.searchParams.get(\"razorpay_payment_link_status\"),\n buyer_phone: url.searchParams.get(\"buyer_phone\"),\n });\n } catch (e: any) {\n console.error(\"payment callback error:\", e?.message);\n }\n return new Response(\"Payment received. You can return to WhatsApp.\", { status: 200 });\n }\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) {\n console.log(\"Webhook verification OK\");\n return new Response(challenge ?? \"\", { status: 200 });\n }\n return new Response(\"Forbidden\", { status: 403 });\n }\n\n // Incoming POST: WhatsApp message OR Razorpay webhook.\n if (req.method === \"POST\") {\n // Read the raw body ONCE. We need the exact text to verify the Razorpay\n // signature, then we parse JSON from that same text.\n const raw = await req.text();\n let body: any = {};\n try { body = JSON.parse(raw); } catch (_) { /* ignore */ }\n\n // --- Razorpay webhook (server-to-server) -------------------------------\n // Razorpay POSTs carry an \"x-razorpay-signature\" header and a top-level\n // \"event\" field. Catch these BEFORE the WhatsApp parser so a payment is\n // never mistaken for a chat message.\n const rzpSignature = req.headers.get(\"x-razorpay-signature\");\n if (rzpSignature || typeof body?.event === \"string\") {\n try { await handleRazorpayWebhook(raw, rzpSignature, body); }\n catch (e: any) { console.error(\"razorpay webhook error:\", e?.message); }\n return new Response(\"OK\", { status: 200 });\n }\n\n // --- Razorpay GET-callback re-posted to /payment (legacy redirect path) -\n if (url.pathname.includes(\"/payment\")) {\n try { await handlePaymentCallback(body); }\n catch (e: any) { console.error(\"payment callback error:\", e?.message); }\n return new Response(\"OK\", { status: 200 });\n }\n\n // --- WhatsApp message ---------------------------------------------------\n console.log(\"RAW INCOMING:\", JSON.stringify(body).slice(0, 500));\n try { await handleMessage(body); }\n catch (e: any) { console.error(\"handleMessage error:\", e?.message || e, e?.stack); }\n return new Response(\"EVENT_RECEIVED\", { status: 200 });\n }\n\n return new Response(\"OK\", { status: 200 });\n}\n\n// ============================================================================\n// WHATSAPP SEND HELPERS — every \"to\" is normalized to digits-only.\n// ============================================================================\nasync function waPost(payload: any): Promise {\n try {\n const r = await fetch(WA_URL, {\n method: \"POST\",\n headers: { Authorization: `Bearer ${WA_TOKEN}`, \"Content-Type\": \"application/json\" },\n body: JSON.stringify(payload),\n });\n const d = await r.json();\n if (!r.ok) { console.error(\"waPost FAILED\", r.status, JSON.stringify(d)); return false; }\n console.log(\"waPost OK to\", payload.to, \"type\", payload.type);\n return true;\n } catch (e: any) {\n console.error(\"waPost EXCEPTION:\", e?.message);\n return false;\n }\n}\n\nasync function sendText(to: string, text: string): Promise {\n const dest = digits(to);\n console.log(`sendText → ${dest}: ${text.slice(0, 80)}`);\n return waPost({ messaging_product: \"whatsapp\", to: dest, type: \"text\", text: { body: text } });\n}\n\nasync function sendButtons(\n to: string, body: string, buttons: { id: string; title: string }[],\n): Promise {\n const dest = digits(to);\n console.log(`sendButtons → ${dest}: ${body.slice(0, 60)}`);\n return waPost({\n messaging_product: \"whatsapp\",\n to: dest,\n type: \"interactive\",\n interactive: {\n type: \"button\",\n body: { text: body },\n action: {\n buttons: buttons.slice(0, 3).map((b) => ({\n type: \"reply\",\n reply: { id: b.id, title: b.title.slice(0, 20) }, // WA limit: 20 chars\n })),\n },\n },\n });\n}\n\nasync function sendList(\n to: string, header: string, body: string, buttonLabel: string,\n rows: { id: string; title: string; description?: string }[],\n): Promise {\n const dest = digits(to);\n console.log(`sendList → ${dest}: ${body.slice(0, 60)}`);\n return waPost({\n messaging_product: \"whatsapp\",\n to: dest,\n type: \"interactive\",\n interactive: {\n type: \"list\",\n header: header ? { type: \"text\", text: header.slice(0, 60) } : undefined,\n body: { text: body },\n action: {\n button: buttonLabel.slice(0, 20),\n sections: [{\n title: \"Categories\",\n rows: rows.slice(0, 10).map((r) => ({\n id: r.id,\n title: r.title.slice(0, 24), // WA limit: 24 chars\n description: r.description?.slice(0, 72), // WA limit: 72 chars\n })),\n }],\n },\n },\n });\n}\n\nasync function sendProTemplate(to: string, category: string): Promise {\n const dest = digits(to);\n console.log(`sendProTemplate → ${dest}, category: ${category}`);\n const ok = await waPost({\n messaging_product: \"whatsapp\",\n to: dest,\n type: \"template\",\n template: {\n name: \"professional_acceptance\",\n language: { code: \"en\" },\n components: [{ type: \"body\", parameters: [{ type: \"text\", text: category }] }],\n },\n });\n return ok;\n}\n\n// ============================================================================\n// SUPABASE DATA LAYER\n// Returns Airtable-shaped objects { id, fields } so the state machine reads\n// familiar field names. Column mapping lives in TABLE_MAP.\n// ============================================================================\nconst first = (rows: any[] | null) => (rows && rows.length ? rows[0] : null);\n\nfunction userObj(r: any) {\n return r ? {\n id: r.id,\n fields: {\n \"Phone Number\": r.phone_number,\n \"Name\": r.name,\n \"Active Session?\": r.active_session,\n \"Bot_State\": r.bot_state,\n \"Pending_Pro_ID\": r.pending_pro_id,\n \"Pending_Pro_Phone\": r.pending_pro_phone,\n \"Pending_Category\": r.pending_category,\n \"Pending_Query\": r.pending_query,\n },\n } : null;\n}\nfunction proObj(r: any) {\n return r ? {\n id: r.id,\n fields: {\n \"Pro Phone\": r.pro_phone,\n \"Pro Name\": r.pro_name,\n \"Specialization\": r.specialization,\n \"Category (from Specialization)\": r.categories || [],\n \"Availability\": r.available,\n \"Rating\": r.rating,\n \"Lifetime Ratings\": r.lifetime_ratings,\n \"Rate\": r.rate,\n },\n } : null;\n}\nfunction sessionObj(r: any) {\n return r ? {\n id: r.id,\n fields: {\n \"Pro Phone\": r.pro_phone,\n \"Status\": r.status,\n \"Rating\": r.rating,\n \"buyer_phone\": r.buyer_phone,\n \"category\": r.category,\n \"query\": r.query,\n \"Users\": r.user_id ? [r.user_id] : [],\n \"Professionals\": r.pro_id ? [r.pro_id] : [],\n },\n } : null;\n}\nconst passObj = (r: any) => (r ? { id: r.id, fields: {} } : null);\n\nconst TABLE_MAP: Record; toObj: (r: any) => any }> = {\n [T_USERS]: {\n pg: \"users\", toObj: userObj,\n toCol: {\n \"Phone Number\": \"phone_number\", \"Name\": \"name\", \"Active Session?\": \"active_session\",\n \"Bot_State\": \"bot_state\", \"Pending_Pro_ID\": \"pending_pro_id\",\n \"Pending_Pro_Phone\": \"pending_pro_phone\", \"Pending_Category\": \"pending_category\",\n \"Pending_Query\": \"pending_query\",\n \"Created Date\": \"created_at\",\n },\n },\n [T_PROS]: {\n pg: \"professionals\", toObj: proObj,\n toCol: {\n \"Pro Phone\": \"pro_phone\", \"Pro Name\": \"pro_name\", \"Specialization\": \"specialization\",\n \"Category (from Specialization)\": \"categories\", \"Availability\": \"available\",\n \"Rating\": \"rating\", \"Lifetime Ratings\": \"lifetime_ratings\", \"Rate\": \"rate\",\n },\n },\n [T_SESSIONS]: {\n pg: \"sessions\", toObj: sessionObj,\n toCol: {\n \"Users\": \"user_id\", \"Professionals\": \"pro_id\", \"Pro Phone\": \"pro_phone\",\n \"Status\": \"status\", \"Rating\": \"rating\", \"IdleWarned\": \"idle_warned\",\n \"buyer_phone\": \"buyer_phone\", \"Phone Number (from Users)\": \"buyer_phone\",\n \"category\": \"category\", \"query\": \"query\",\n },\n },\n [T_WAITLIST]: {\n pg: \"waitlist\", toObj: passObj,\n toCol: {\n \"User_Phone\": \"user_phone\", \"Category\": \"category\", \"Query\": \"query\",\n \"Status\": \"status\", \"Joined_At\": \"joined_at\",\n },\n },\n [T_LOGS]: {\n pg: \"interaction_logs\", toObj: passObj,\n toCol: {\n \"Sessions\": \"session_id\", \"Direction\": \"direction\", \"Content\": \"content\",\n \"Timestamp\": \"created_at\",\n },\n },\n [T_ERRORS]: {\n pg: \"error_logs\", toObj: passObj,\n toCol: {\n \"Workflow\": \"workflow\", \"Failed_Node\": \"failed_node\", \"Error_Message\": \"error_message\",\n \"Timestamp\": \"created_at\", \"Sender_Phone\": \"sender_phone\", \"Raw_Message\": \"raw_message\",\n },\n },\n};\n\n// FK columns that take the first element of an Airtable-style [id] array.\nconst ARRAY_TO_SCALAR = new Set([\"user_id\", \"pro_id\", \"session_id\"]);\n\nfunction translateFields(tableId: string, fields: Record) {\n const map = TABLE_MAP[tableId];\n const out: Record = {};\n for (const [k, v] of Object.entries(fields)) {\n const col = map.toCol[k];\n if (!col) { console.warn(`DB: skipping unknown field \"${k}\" on ${map.pg}`); continue; }\n out[col] = (ARRAY_TO_SCALAR.has(col) && Array.isArray(v)) ? (v[0] ?? null) : v;\n }\n return out;\n}\n\n// Generic create. Returns null on failure (callers MUST check), so we never\n// pretend a row exists when the insert actually failed.\nasync function atCreate(tableId: string, fields: any): Promise {\n const map = TABLE_MAP[tableId];\n const { data, error } = await sb.from(map.pg).insert(translateFields(tableId, fields)).select();\n if (error) { console.error(\"atCreate FAILED\", map.pg, error.message); return null; }\n return map.toObj(first(data));\n}\nasync function atUpdate(tableId: string, id: string, fields: any): Promise {\n const map = TABLE_MAP[tableId];\n const { data, error } = await sb.from(map.pg).update(translateFields(tableId, fields)).eq(\"id\", id).select();\n if (error) { console.error(\"atUpdate FAILED\", map.pg, id, error.message); return null; }\n return map.toObj(first(data));\n}\n\n// ---- Named lookups (all phone-format tolerant) -----------------------------\nasync function findUserByPhone(phone: string) {\n const { data, error } = await sb.from(\"users\").select(\"*\").or(phoneOr(\"phone_number\", phone)).limit(1);\n if (error) { console.error(\"findUserByPhone\", error.message); return null; }\n return userObj(first(data));\n}\nasync function findProByPhone(phone: string) {\n const { data, error } = await sb.from(\"professionals\").select(\"*\").or(phoneOr(\"pro_phone\", phone)).limit(1);\n if (error) { console.error(\"findProByPhone\", error.message); return null; }\n return proObj(first(data));\n}\nasync function findSessionByProStatus(proPhone: string, status: string) {\n const { data, error } = await sb.from(\"sessions\").select(\"*\").or(phoneOr(\"pro_phone\", proPhone)).eq(\"status\", status).limit(1);\n if (error) { console.error(\"findSessionByProStatus\", error.message); return null; }\n return sessionObj(first(data));\n}\nasync function findActiveOrPausedByPro(proPhone: string) {\n const { data, error } = await sb.from(\"sessions\").select(\"*\").or(phoneOr(\"pro_phone\", proPhone)).in(\"status\", [\"Active\", \"Paused\"]).limit(1);\n if (error) { console.error(\"findActiveOrPausedByPro\", error.message); return null; }\n return sessionObj(first(data));\n}\nasync function findSessionByUserStatus(userId: string, status: string) {\n const { data, error } = await sb.from(\"sessions\").select(\"*\").eq(\"user_id\", userId).eq(\"status\", status).limit(1);\n if (error) { console.error(\"findSessionByUserStatus\", error.message); return null; }\n return sessionObj(first(data));\n}\n\n// Resolve the buyer's phone for a session. Prefer the denormalized column;\n// fall back to the linked user row. RELAY-FIX: guarantees pro→buyer works.\nasync function getBuyerPhone(session: any): Promise {\n let phone = session?.fields?.[\"buyer_phone\"] || null;\n if (!phone) {\n const userId = session?.fields?.[\"Users\"]?.[0];\n if (userId) {\n const { data } = await sb.from(\"users\").select(\"phone_number\").eq(\"id\", userId).limit(1);\n phone = first(data)?.phone_number || null;\n }\n }\n const out = phone ? digits(phone) : null;\n console.log(\"getBuyerPhone:\", out);\n return out;\n}\n\nasync function findPro(category: string, excludePhone?: string): Promise {\n let q = sb.from(\"professionals\").select(\"*\").contains(\"categories\", [category]).eq(\"available\", true);\n if (excludePhone) {\n const d = digits(excludePhone);\n q = q.neq(\"pro_phone\", d).neq(\"pro_phone\", `+${d}`);\n }\n const { data, error } = await q.order(\"rating\", { ascending: false }).limit(1);\n if (error) { console.error(\"findPro FAILED\", category, error.message); return null; }\n return proObj(first(data));\n}\n\nasync function logInteraction(sessionId: string, direction: string, content: string) {\n try {\n await atCreate(T_LOGS, {\n Sessions: [sessionId], Direction: direction, Content: content,\n Timestamp: new Date().toISOString(),\n });\n } catch (_) { /* logging must never break a relay */ }\n}\nasync function logError(node: string, msg: string, sender: string, raw: string) {\n try {\n await atCreate(T_ERRORS, {\n Workflow: \"GoodBeetle Bot\", Failed_Node: node, Error_Message: msg,\n Timestamp: new Date().toISOString(), Sender_Phone: sender, Raw_Message: raw,\n });\n } catch (_) { /* ignore */ }\n}\n\n// ============================================================================\n// GPT CATEGORY CLASSIFIER\n// ============================================================================\nasync function classify(query: string): Promise {\n const sys =\n \"You are a category classifier for a professional consultation marketplace. \" +\n \"Given a user's query, return ONLY one of these exact category names, nothing else: \" +\n \"Legal, Tax & GST, Startup & Compliance, Tech, Fitness, Nutrition, HR & Labour, \" +\n \"Marketing, Product, Astrology, Vastu. If the query does not match any category, \" +\n \"return exactly: NO_MATCH. Do not explain. Do not add punctuation.\";\n try {\n const r = await fetch(\"https://api.openai.com/v1/chat/completions\", {\n method: \"POST\",\n headers: { Authorization: `Bearer ${OPENAI_KEY}`, \"Content-Type\": \"application/json\" },\n body: JSON.stringify({\n model: \"gpt-4o-mini\", temperature: 0,\n messages: [{ role: \"system\", content: sys }, { role: \"user\", content: query }],\n }),\n });\n const d = await r.json();\n const out = (d.choices?.[0]?.message?.content || \"\").trim();\n return CATEGORIES.includes(out) ? out : \"NO_MATCH\";\n } catch (e: any) {\n console.error(\"classify error:\", e?.message);\n return \"NO_MATCH\";\n }\n}\n\n// ============================================================================\n// RAZORPAY PAYMENT\n// ============================================================================\nasync function createPaymentLink(\n buyerPhone: string, category: string, proName: string, amountPaise: number,\n): Promise {\n if (!RZP_KEY_ID || !RZP_SECRET) { console.log(\"Razorpay not configured — skipping\"); return null; }\n const auth = btoa(`${RZP_KEY_ID}:${RZP_SECRET}`);\n const phone = digits(buyerPhone);\n const payload = {\n amount: amountPaise,\n currency: \"INR\",\n description: `GoodBeetle: ${category} consultation with ${proName}`,\n customer: { contact: `+${phone}` },\n notify: { whatsapp: false, sms: false, email: false },\n reminder_enable: false,\n callback_url: `${PUBLIC_URL.replace(/\\/$/, \"\")}/payment?buyer_phone=${phone}`,\n callback_method: \"get\",\n notes: { buyer_phone: phone, category },\n };\n try {\n const r = await fetch(\"https://api.razorpay.com/v1/payment_links\", {\n method: \"POST\",\n headers: { Authorization: `Basic ${auth}`, \"Content-Type\": \"application/json\" },\n body: JSON.stringify(payload),\n });\n const d = await r.json();\n if (!r.ok) { console.error(\"Razorpay createPaymentLink FAILED:\", JSON.stringify(d)); return null; }\n console.log(\"Razorpay link created:\", d.short_url);\n return d.short_url || null;\n } catch (e: any) {\n console.error(\"Razorpay exception:\", e?.message);\n return null;\n }\n}\n\nasync function handlePaymentCallback(body: any) {\n const status = body?.razorpay_payment_link_status;\n const buyerPhone = digits(body?.buyer_phone || body?.notes?.buyer_phone || \"\");\n console.log(\"Payment callback status:\", status, \"buyer:\", buyerPhone);\n if (status !== \"paid\" || !buyerPhone) return;\n\n const user = await findUserByPhone(buyerPhone);\n if (!user) { console.error(\"Payment callback: user not found\", buyerPhone); return; }\n if (user.fields?.Bot_State !== \"AWAITING_PAYMENT\") {\n console.log(\"Payment callback: user not awaiting payment, ignoring\");\n return;\n }\n await atUpdate(T_USERS, user.id, { Bot_State: \"IN_SESSION\" }); // guard against double-trigger\n await sendText(buyerPhone, \"✅ Payment received! Connecting you with your expert now…\");\n await createSession(buyerPhone, user);\n}\n\n// Verify a Razorpay webhook is genuine: HMAC-SHA256 of the raw body with our\n// webhook secret must equal the signature Razorpay sent in the header.\nasync function verifyRazorpaySignature(raw: string, signature: string | null): Promise {\n if (!RZP_WEBHOOK_SECRET) { console.warn(\"RAZORPAY_WEBHOOK_SECRET not set — cannot verify webhook\"); return false; }\n if (!signature) return false;\n const key = await crypto.subtle.importKey(\n \"raw\", new TextEncoder().encode(RZP_WEBHOOK_SECRET),\n { name: \"HMAC\", hash: \"SHA-256\" }, false, [\"sign\"],\n );\n const sigBuf = await crypto.subtle.sign(\"HMAC\", key, new TextEncoder().encode(raw));\n const expected = [...new Uint8Array(sigBuf)].map((b) => b.toString(16).padStart(2, \"0\")).join(\"\");\n if (expected.length !== signature.length) return false;\n let diff = 0;\n for (let i = 0; i < expected.length; i++) diff |= expected.charCodeAt(i) ^ signature.charCodeAt(i);\n return diff === 0; // constant-time-ish compare\n}\n\n// The reliable, server-to-server confirmation path. Fires even if the buyer\n// closes WhatsApp right after paying.\nasync function handleRazorpayWebhook(raw: string, signature: string | null, body: any) {\n // 1) Make sure it's really from Razorpay.\n if (!(await verifyRazorpaySignature(raw, signature))) {\n console.warn(\"Razorpay webhook: invalid signature — ignoring\");\n return;\n }\n\n // 2) We only act on a successful payment-link payment.\n if (body?.event !== \"payment_link.paid\") {\n console.log(\"Razorpay webhook:\", body?.event, \"— ignoring\");\n return;\n }\n\n // 3) Recover the buyer's phone from the link notes we set in createPaymentLink.\n const linkEntity = body?.payload?.payment_link?.entity;\n const buyerPhone = digits(linkEntity?.notes?.buyer_phone || \"\");\n console.log(\"Razorpay webhook PAID — buyer:\", buyerPhone, \"link:\", linkEntity?.id);\n if (!buyerPhone) { console.error(\"Razorpay webhook: no buyer_phone in notes\"); return; }\n\n // 4) Connect the buyer — same success logic as the redirect callback.\n const user = await findUserByPhone(buyerPhone);\n if (!user) { console.error(\"Razorpay webhook: user not found\", buyerPhone); return; }\n if (user.fields?.Bot_State !== \"AWAITING_PAYMENT\") {\n console.log(\"Razorpay webhook: user not awaiting payment — already connected, ignoring\");\n return;\n }\n await atUpdate(T_USERS, user.id, { Bot_State: \"IN_SESSION\" }); // guard against double-trigger\n await sendText(buyerPhone, \"✅ Payment received! Connecting you with your expert now…\");\n await createSession(buyerPhone, user);\n}\n\n// ============================================================================\n// UI HELPERS (crisp copy + buttons everywhere)\n// ============================================================================\nconst CATEGORY_ROWS = [\n { id: \"legal\", title: \"⚖️ Legal\", description: \"Contracts, disputes, notices\" },\n { id: \"tax\", title: \"💰 Tax & GST\", description: \"Filing, GST, tax planning\" },\n { id: \"startup\", title: \"🚀 Startup & Compliance\", description: \"Incorporation, ROC, funding\" },\n { id: \"tech\", title: \"💻 Tech\", description: \"Software, websites, IT help\" },\n { id: \"fitness\", title: \"💪 Fitness\", description: \"Training & workout plans\" },\n { id: \"nutrition\", title: \"🍎 Nutrition\", description: \"Diet & meal guidance\" },\n { id: \"hr\", title: \"🏢 HR & Labour\", description: \"Hiring, payroll, labour law\" },\n { id: \"marketing\", title: \"📣 Marketing\", description: \"Branding, ads, growth\" },\n { id: \"product\", title: \"🛠️ Product\", description: \"Product & design advice\" },\n { id: \"astrology\", title: \"🔮 Astrology\", description: \"Readings & guidance\" },\n { id: \"vastu\", title: \"🏠 Vastu\", description: \"Space & layout advice\" },\n { id: \"other\", title: \"💬 Other\", description: \"Not sure? Describe it\" },\n];\n\nasync function showCategoryList(to: string, exclude: string[] = []) {\n const rows = CATEGORY_ROWS.filter((r) => !exclude.includes(CAT_BY_ID[r.id]));\n await sendList(to, \"GoodBeetle\", \"Pick what you need help with 👇\", \"Choose category\", rows);\n}\n\nasync function sendConsultantCard(to: string, pro: any, category: string) {\n const f = pro.fields;\n const rating = f[\"Rating\"] ? `⭐ ${f[\"Rating\"]}/5` : \"⭐ New\";\n const rate = f[\"Rate\"] ? `₹${f[\"Rate\"]}` : \"₹499\";\n const body =\n `*${f[\"Pro Name\"]}*\\n` +\n `${category} expert · ${rating}\\n` +\n `💵 ${rate} per session · ✅ Available now`;\n await sendButtons(to, body, [\n { id: \"confirm\", title: \"✅ Book expert\" },\n { id: \"change\", title: \"🔄 See another\" },\n { id: \"cancel\", title: \"✕ Cancel\" },\n ]);\n}\n\n// ============================================================================\n// MESSAGE PARSER\n// ============================================================================\ntype Msg = {\n sender: string; type: string; text: string; title: string;\n isInteractive: boolean; name: string;\n};\n\nfunction parse(body: any): Msg | null {\n try {\n const value = body?.entry?.[0]?.changes?.[0]?.value;\n const m = value?.messages?.[0];\n if (!m) return null;\n const sender = digits(m.from); // normalized\n const name = value?.contacts?.[0]?.profile?.name || \"\";\n if (m.type === \"text\") {\n return { sender, type: \"text\", text: (m.text?.body || \"\").trim(), title: \"\", isInteractive: false, name };\n }\n if (m.type === \"interactive\") {\n const btn = m.interactive?.button_reply;\n const list = m.interactive?.list_reply;\n const id = btn?.id || list?.id || \"\";\n const title = btn?.title || list?.title || \"\";\n return { sender, type: \"interactive\", text: id || title, title, isInteractive: true, name };\n }\n if (m.type === \"button\") {\n // Quick-reply button on an APPROVED TEMPLATE (e.g. professional_acceptance).\n // These arrive differently from the bot's own interactive buttons.\n const label = m.button?.text || m.button?.payload || \"\";\n return { sender, type: \"button\", text: label, title: label, isInteractive: true, name };\n }\n return { sender, type: m.type, text: \"\", title: \"\", isInteractive: false, name };\n } catch (_) {\n return null;\n }\n}\n\n// ============================================================================\n// UTILITIES\n// ============================================================================\nconst RELAY_CMDS = [\"CLOSE\", \"PAUSE\", \"RESUME\", \"HELP\"];\nconst isRelayCmd = (t: string) => RELAY_CMDS.includes(t.trim().toUpperCase());\nconst lc = (t: string) => t.trim().toLowerCase();\n\n// A message counts as \"end the session\" only if the WHOLE message is one of\n// these (equality, not substring) — so a real message like \"by month end\"\n// isn't mistaken for a close command.\nconst CLOSE_WORDS = new Set([\n \"close\", \"end\", \"done\", \"finish\", \"stop\", \"exit\", \"quit\", \"bye\",\n \"end session\", \"close session\", \"end chat\", \"close chat\", \"end the session\",\n \"band karo\", \"khatam\", \"khatam karo\", \"/end\", \"#end\",\n]);\nconst isCloseRequest = (t: string) => CLOSE_WORDS.has(lc(t));\n\nfunction selectionIntent(t: string): \"confirm\" | \"cancel\" | \"change\" | null {\n const s = lc(t);\n if ([\"yes\", \"ok\", \"okay\", \"confirm\", \"sure\", \"haan\", \"ha\", \"book\"].includes(s)) return \"confirm\";\n if ([\"no\", \"cancel\", \"nahi\", \"nope\"].includes(s)) return \"cancel\";\n if ([\"change\", \"other\", \"next\", \"aur\", \"different\", \"someone\"].includes(s)) return \"change\";\n return null;\n}\n\nfunction ratingFromText(t: string): number | null {\n const s = lc(t);\n if (/^[1-5]$/.test(s)) return parseInt(s, 10);\n if ([\"bad\", \"terrible\", \"worst\"].includes(s)) return 1;\n if ([\"good\", \"great\", \"excellent\", \"awesome\"].includes(s)) return 5;\n if ([\"okay\", \"fine\", \"average\"].includes(s)) return 3;\n return null;\n}\n\n// Simple in-memory dedupe (resets on cold start — fine for our purposes).\nconst recent = new Map();\n\n// ============================================================================\n// PRO PATH (relay + session controls)\n// ============================================================================\nasync function handleProPath(pro: any, msg: Msg) {\n const proPhone = msg.sender; // digits-only\n const session = await findSessionByProStatus(proPhone, \"Active\");\n const paused = await findSessionByProStatus(proPhone, \"Paused\");\n const cmd = msg.text.trim().toUpperCase();\n const titleLower = (msg.title || msg.text).trim().toLowerCase();\n // Letters-only key so template labels match regardless of apostrophe style,\n // spacing or punctuation: \"Let's Start\" / \"Let’s Start\" → \"letsstart\".\n const titleKey = (msg.title || msg.text).toLowerCase().replace(/[^a-z]/g, \"\");\n\n console.log(`handleProPath: cmd=\"${cmd}\" title=\"${titleLower}\" key=\"${titleKey}\" session=${session?.id} paused=${paused?.id}`);\n\n // --- Template button responses (from the professional_acceptance template) ---\n if (titleKey === \"letsstart\" && paused) {\n await atUpdate(T_SESSIONS, paused.id, { Status: \"Active\" });\n const cat = paused.fields[\"category\"] || \"\";\n const q = (paused.fields[\"query\"] || \"\").trim();\n const buyer = await getBuyerPhone(paused);\n let buyerName = \"your client\";\n if (buyer) {\n const bu = await findUserByPhone(buyer);\n buyerName = bu?.fields?.[\"Name\"] || \"your client\";\n }\n const context = q\n ? `📋 *What ${buyerName} needs:*\\n\"${q}\"`\n : `📋 _${buyerName} didn't add details — feel free to ask what they need._`;\n await sendButtons(msg.sender,\n `✅ You're connected${cat ? ` for a *${cat}* consultation` : \"\"}.\\n\\n${context}\\n\\nTap below to break the ice, or just start typing. Type *END* when you're done.`,\n [{ id: \"send_greeting\", title: \"👋 Say hi\" }, { id: \"CLOSE\", title: \"✅ End session\" }]);\n if (buyer) {\n await sendText(buyer, \"✅ Your expert has joined! Connecting you now…\\n\\n_(Type *END* anytime to finish.)_\");\n }\n return;\n }\n if (titleKey === \"notavailable\" && paused) {\n await atUpdate(T_SESSIONS, paused.id, { Status: \"Closed\" });\n await sendText(msg.sender, \"Got it — declined. You won't be disturbed for this request.\");\n const buyer = await getBuyerPhone(paused);\n if (buyer) {\n const buyerUser = await findUserByPhone(buyer);\n const cat = buyerUser?.fields?.Pending_Category || \"\";\n const altPro = cat ? await findPro(cat, proPhone) : null;\n if (altPro && buyerUser) {\n await atUpdate(T_USERS, buyerUser.id, {\n Bot_State: \"AWAITING_SELECTION\",\n Pending_Pro_ID: altPro.id,\n Pending_Pro_Phone: altPro.fields[\"Pro Phone\"],\n });\n await sendText(buyer, \"That expert just got busy. Here's another great option:\");\n await sendConsultantCard(buyer, altPro, cat);\n } else if (buyerUser) {\n await atUpdate(T_USERS, buyerUser.id, { Bot_State: \"POST_SESSION\", \"Active Session?\": false });\n await atCreate(T_WAITLIST, {\n User_Phone: buyer, Category: cat, Query: \"\", Status: \"Waiting\",\n Joined_At: new Date().toISOString(),\n });\n await sendButtons(buyer,\n \"All experts in this category are busy right now. We've added you to the waitlist and will ping you the moment one is free.\\n\\nIf you paid, a refund will be processed within 24 hours.\",\n [{ id: \"new_consult\", title: \"🔁 Try another\" }]);\n }\n }\n return;\n }\n if (titleKey === \"pleasewait\" && paused) {\n await sendText(msg.sender, \"⏸️ Okay, client is on hold. Send *RESUME* when you're ready.\");\n const buyer = await getBuyerPhone(paused);\n if (buyer) await sendText(buyer, \"⏸️ Your expert is finishing something and will be with you shortly.\");\n return;\n }\n\n if (cmd === \"HELP\") {\n await sendButtons(msg.sender, \"Session controls:\",\n [{ id: \"PAUSE\", title: \"⏸ Pause\" }, { id: \"RESUME\", title: \"▶️ Resume\" }, { id: \"CLOSE\", title: \"✅ End\" }]);\n return;\n }\n if (cmd === \"RESUME\" && paused) {\n await atUpdate(T_SESSIONS, paused.id, { Status: \"Active\" });\n await sendText(msg.sender, \"▶️ Session resumed.\");\n const buyer = await getBuyerPhone(paused);\n if (buyer) await sendText(buyer, \"▶️ Your expert is back. Go ahead!\");\n return;\n }\n\n if (!session && !paused) {\n await sendText(msg.sender, \"No active client session. You'll be notified the moment a client books you.\");\n return;\n }\n if (!session && paused) {\n await sendButtons(msg.sender, \"This session is on hold.\", [{ id: \"RESUME\", title: \"▶️ Resume\" }]);\n return;\n }\n\n const buyerPhone = await getBuyerPhone(session!);\n if (cmd === \"CLOSE\" || isCloseRequest(msg.text)) { await closeSession(session!, pro.fields[\"Pro Name\"], buyerPhone); return; }\n if (msg.text === \"send_greeting\") {\n const cat = session!.fields[\"category\"] || \"\";\n const proName = pro.fields[\"Pro Name\"] || \"your expert\";\n if (buyerPhone) {\n await sendText(buyerPhone,\n `👋 Hi, I'm *${proName}*${cat ? ` — happy to help with your ${cat} query` : \"\"}. What's going on?`);\n await logInteraction(session!.id, \"Pro -> Buyer\", `Hi, I'm ${proName}`);\n }\n await sendText(msg.sender, \"Sent ✅ Carry on chatting — type *END* when you're done.\");\n return;\n }\n if (cmd === \"PAUSE\") {\n await atUpdate(T_SESSIONS, session!.id, { Status: \"Paused\" });\n await sendButtons(msg.sender, \"⏸️ Session paused.\", [{ id: \"RESUME\", title: \"▶️ Resume\" }]);\n if (buyerPhone) await sendText(buyerPhone, \"⏸️ Your expert has paused briefly and will be back soon.\");\n return;\n }\n\n if (!msg.text) {\n await sendText(msg.sender, \"Only text can be relayed right now — please describe it in words or paste a link.\");\n return;\n }\n\n // --- RELAY: pro → buyer ---\n if (buyerPhone) {\n await sendText(buyerPhone, msg.text);\n await logInteraction(session!.id, \"Pro -> Buyer\", msg.text);\n } else {\n console.error(\"handleProPath: could not resolve buyer phone for session\", session!.id);\n await logError(\"relay_pro_to_buyer\", \"buyer phone missing\", proPhone, msg.text);\n await sendText(msg.sender, \"⚠️ Couldn't reach the client. Our team has been alerted.\");\n await sendText(ADMIN_PHONE, `⚠️ Relay failed: no buyer phone on session ${session!.id} (pro ${proPhone}).`);\n }\n}\n\n// ============================================================================\n// SESSION CLOSE + FEEDBACK\n// ============================================================================\nasync function closeSession(session: any, proName: string, buyerPhone: string | null) {\n await atUpdate(T_SESSIONS, session.id, { Status: \"Closed\" });\n const proPhone = session.fields[\"Pro Phone\"];\n if (proPhone) await sendText(proPhone, `Session closed ✅\\n\\nThanks for your time, ${proName}!`);\n if (buyerPhone) {\n const user = await findUserByPhone(buyerPhone);\n if (user) await atUpdate(T_USERS, user.id, { \"Active Session?\": false, Bot_State: \"AWAITING_FEEDBACK\" });\n await sendButtons(buyerPhone,\n `Your session with *${proName}* has ended.\\n\\nHow would you rate it?`,\n [\n { id: \"rate_1\", title: \"⭐ Poor\" },\n { id: \"rate_3\", title: \"⭐⭐⭐ Okay\" },\n { id: \"rate_5\", title: \"⭐⭐⭐⭐⭐ Great\" },\n ]);\n }\n}\n\n// Cancel a session the pro never accepted (buyer bailed while waiting).\nasync function cancelPendingSession(sender: string, user: any, session: any) {\n await atUpdate(T_SESSIONS, session.id, { Status: \"Closed\" });\n await atUpdate(T_USERS, user.id, {\n \"Active Session?\": false, Bot_State: \"AWAITING_QUERY\",\n Pending_Pro_ID: \"\", Pending_Pro_Phone: \"\", Pending_Category: \"\", Pending_Query: \"\",\n });\n // Let the pro know the request was withdrawn (harmless if it never reached them).\n const proPhone = session.fields[\"Pro Phone\"];\n if (proPhone) await sendText(proPhone, \"The client withdrew this request before it started. No action needed.\");\n await sendButtons(sender, \"Cancelled — you're not connected to anyone. Start a new request whenever you like.\",\n [{ id: \"new_consult\", title: \"🔁 New request\" }]);\n}\n\n// ============================================================================\n// MAIN MESSAGE HANDLER\n// ============================================================================\nasync function handleMessage(body: any) {\n const msg = parse(body);\n if (!msg) { console.log(\"No parseable message — likely a status update, skipping\"); return; }\n\n // Dedupe identical sender+text within 5s.\n const key = msg.sender + \"|\" + msg.text;\n const now = Date.now();\n if (recent.has(key) && now - (recent.get(key) || 0) < 5000) { console.log(\"Deduped:\", key); return; }\n recent.set(key, now);\n if (recent.size > 500) recent.clear();\n\n const sender = msg.sender;\n console.log(`MSG from ${sender}: type=${msg.type} text=\"${msg.text}\" title=\"${msg.title}\"`);\n\n try {\n const pro = await findProByPhone(sender);\n let user = await findUserByPhone(sender);\n const state: string = user?.fields?.Bot_State || \"\";\n\n // ── Pro routing ──────────────────────────────────────────────────────\n if (pro) {\n const hasActiveSession = await findActiveOrPausedByPro(sender);\n if (hasActiveSession || isRelayCmd(msg.text)) {\n return await handleProPath(pro, msg);\n }\n if (state === \"PRO_OR_BUYER_PENDING\") {\n if (msg.text === \"as_pro\") {\n if (user) await atUpdate(T_USERS, user.id, { Bot_State: \"\" });\n return await handleProPath(pro, msg);\n }\n if (msg.text === \"as_buyer\") {\n if (!user) user = await atCreate(T_USERS, { \"Phone Number\": sender, Name: msg.name, Bot_State: \"AWAITING_QUERY\" });\n else await atUpdate(T_USERS, user.id, { Bot_State: \"AWAITING_QUERY\" });\n const own = pro.fields[\"Category (from Specialization)\"] || [];\n await showCategoryList(sender, own);\n return;\n }\n await sendButtons(sender,\n \"Quick check — how are you using GoodBeetle right now?\",\n [{ id: \"as_pro\", title: \"👔 I have a client\" }, { id: \"as_buyer\", title: \"🙋 I need advice\" }]);\n return;\n }\n // Pro with no active session and not in a flow — ask intent.\n if (!user) user = await atCreate(T_USERS, { \"Phone Number\": sender, Name: msg.name, Bot_State: \"PRO_OR_BUYER_PENDING\" });\n else await atUpdate(T_USERS, user.id, { Bot_State: \"PRO_OR_BUYER_PENDING\" });\n await sendButtons(sender,\n \"👋 Hey! How are you using GoodBeetle right now?\",\n [{ id: \"as_pro\", title: \"👔 I have a client\" }, { id: \"as_buyer\", title: \"🙋 I need advice\" }]);\n return;\n }\n\n // ── Global text commands ─────────────────────────────────────────────\n const low = lc(msg.text);\n if (!msg.isInteractive && [\"menu\", \"start\", \"hi\", \"hello\", \"hey\"].includes(low)) {\n return await reprompt(sender, user, state, msg.name);\n }\n if (!msg.isInteractive && low === \"help\") {\n return await contextHelp(sender, state);\n }\n\n // ── New buyer (with loud-failure handling — fixes the welcome loop) ───\n if (!user) {\n const name = msg.name || \"there\";\n user = await atCreate(T_USERS, { \"Phone Number\": sender, Name: msg.name, Bot_State: \"AWAITING_QUERY\" });\n if (!user) {\n // Insert genuinely failed (schema mismatch / wrong key). Don't loop silently.\n console.error(\"New-buyer create FAILED for\", sender);\n await logError(\"create_user\", \"insert returned null\", sender, JSON.stringify(body).slice(0, 500));\n await sendText(sender, \"Sorry, something went wrong on our side. Please try again in a moment 🙏\");\n await sendText(ADMIN_PHONE, `⚠️ Could not create user ${sender}. Check Supabase schema / service_role key.`);\n return;\n }\n await sendText(sender, `👋 Welcome to *GoodBeetle*, ${name}!\\n\\nVerified experts, on-demand, right here on WhatsApp.`);\n // If their very first message already says what they want, act on it now\n // instead of just re-showing the menu.\n if (msg.isInteractive || (msg.type === \"text\" && msg.text)) {\n return await phaseAwaitingQuery(sender, user, msg, pro);\n }\n await showCategoryList(sender);\n return;\n }\n\n // ── State router ─────────────────────────────────────────────────────\n switch (state) {\n case \"\":\n case \"AWAITING_QUERY\": return await phaseAwaitingQuery(sender, user, msg, pro);\n case \"AWAITING_DETAILS\": return await phaseAwaitingDetails(sender, user, msg, pro);\n case \"AWAITING_SELECTION\": return await phaseSelection(sender, user, msg);\n case \"AWAITING_PAYMENT\": return await phaseAwaitingPayment(sender, user, msg);\n case \"IN_SESSION\": return await phaseInSession(sender, user, msg);\n case \"AWAITING_FEEDBACK\": return await phaseFeedback(sender, user, msg);\n case \"GRIEVANCE\": return await phaseGrievance(sender, user, msg);\n case \"POST_SESSION\": return await phasePostSession(sender, user, msg);\n default:\n await atUpdate(T_USERS, user.id, { Bot_State: \"AWAITING_QUERY\" });\n await showCategoryList(sender);\n return;\n }\n } catch (e: any) {\n console.error(\"handleMessage outer catch:\", e?.message, e?.stack);\n await logError(\"handleMessage\", String(e?.message || e), sender, JSON.stringify(body).slice(0, 1000));\n }\n}\n\n// ============================================================================\n// STATE HANDLERS\n// ============================================================================\nasync function phaseAwaitingQuery(sender: string, user: any, msg: Msg, pro: any) {\n if (msg.isInteractive) {\n if (msg.text === \"other\") {\n await atUpdate(T_USERS, user.id, { Pending_Category: \"UNKNOWN\", Bot_State: \"AWAITING_QUERY\" });\n await sendText(sender, \"No problem! Tell me in a sentence what you need, and I'll find the right expert.\");\n return;\n }\n const category = CAT_BY_ID[msg.text];\n if (category) {\n // A pro can't pick their own category when acting as a buyer.\n if (pro) {\n const own: string[] = (pro.fields[\"Category (from Specialization)\"] || [])\n .map((c: any) => (typeof c === \"string\" ? c : c?.name || \"\"));\n if (own.includes(category)) {\n await sendText(sender, `You're a ${category} expert yourself! Pick a different category for your own query.`);\n await showCategoryList(sender, own);\n return;\n }\n }\n await atUpdate(T_USERS, user.id, {\n Pending_Category: category, Bot_State: \"AWAITING_DETAILS\", Pending_Query: \"\",\n });\n await sendText(sender,\n `Got it — *${category}*. In one line, what do you need help with?\\n\\n_(We share this with your expert so they can prepare.)_`);\n return;\n }\n if ([\"wl_join\", \"wl_diff\", \"wl_never\"].includes(msg.text)) {\n return await unknownWaitlistChoice(sender, user, msg.text);\n }\n }\n\n // Second attempt after \"Other\" → free text.\n if (user.fields?.Pending_Category === \"UNKNOWN\" && msg.type === \"text\" && msg.text) {\n const cat2 = await classify(msg.text);\n if (cat2 !== \"NO_MATCH\") {\n await atUpdate(T_USERS, user.id, { Pending_Category: cat2, Pending_Query: msg.text });\n return await tryFindPro(sender, user, cat2, pro, msg.text);\n }\n await atUpdate(T_USERS, user.id, { Pending_Pro_ID: msg.text }); // stash description\n await sendButtons(sender,\n \"We don't cover that category *yet* — but we're growing fast. Want us to notify you?\",\n [\n { id: \"wl_join\", title: \"✅ Notify me\" },\n { id: \"wl_diff\", title: \"🔄 Pick another\" },\n { id: \"wl_never\", title: \"✕ Never mind\" },\n ]);\n return;\n }\n\n // Free-text query.\n if (msg.type === \"text\" && msg.text) {\n const cat = await classify(msg.text);\n if (cat === \"NO_MATCH\") {\n await sendText(sender, \"I'm not sure which category fits. Pick one below 👇\");\n await showCategoryList(sender);\n return;\n }\n await atUpdate(T_USERS, user.id, { Pending_Category: cat, Pending_Query: msg.text });\n return await tryFindPro(sender, user, cat, pro, msg.text);\n }\n\n await showCategoryList(sender);\n}\n\n// Buyer describes their need (one line) after tapping a category, then we match.\nasync function phaseAwaitingDetails(sender: string, user: any, msg: Msg, pro: any) {\n const category = user.fields?.Pending_Category;\n if (!category || category === \"UNKNOWN\") {\n await atUpdate(T_USERS, user.id, { Bot_State: \"AWAITING_QUERY\" });\n await showCategoryList(sender);\n return;\n }\n // Whatever they typed becomes the query the expert will see (blank is OK).\n const query = msg.type === \"text\" && msg.text ? msg.text.trim() : \"\";\n await atUpdate(T_USERS, user.id, { Pending_Query: query });\n return await tryFindPro(sender, user, category, pro, query || undefined);\n}\n\nasync function unknownWaitlistChoice(sender: string, user: any, choice: string) {\n if (choice === \"wl_join\") {\n const desc = user.fields?.Pending_Pro_ID || \"your request\";\n await atCreate(T_WAITLIST, {\n User_Phone: sender, Category: \"UNKNOWN\", Query: desc, Status: \"Waiting\",\n Joined_At: new Date().toISOString(),\n });\n await atUpdate(T_USERS, user.id, { Bot_State: \"POST_SESSION\", Pending_Category: \"\", Pending_Pro_ID: \"\" });\n await sendText(sender, \"Done ✅ You're on the list — we'll WhatsApp you the moment an expert is available.\");\n return;\n }\n if (choice === \"wl_diff\") {\n await atUpdate(T_USERS, user.id, { Pending_Category: \"\", Pending_Pro_ID: \"\" });\n await showCategoryList(sender);\n return;\n }\n await atUpdate(T_USERS, user.id, { Bot_State: \"AWAITING_QUERY\", Pending_Category: \"\", Pending_Pro_ID: \"\" });\n await sendText(sender, \"No problem — come back anytime 👋\");\n}\n\nasync function tryFindPro(sender: string, user: any, category: string, pro: any, queryText?: string) {\n // A pro can't be matched to their own category.\n if (pro) {\n const own: string[] = (pro.fields[\"Category (from Specialization)\"] || [])\n .map((c: any) => (typeof c === \"string\" ? c : c?.name || \"\"));\n if (own.includes(category)) {\n await sendText(sender, `You're a ${category} expert yourself! Pick a different category for your own query.`);\n await showCategoryList(sender, own);\n return;\n }\n }\n if (queryText) await atUpdate(T_USERS, user.id, { Pending_Category: category });\n\n const found = await findPro(category);\n if (!found) {\n await atUpdate(T_USERS, user.id, { Pending_Category: category, Pending_Pro_Phone: \"WAIT\" });\n await sendButtons(sender,\n `All our ${category} experts are with clients right now. Want us to ping you the moment one is free?`,\n [{ id: \"wl_join2\", title: \"✅ Join waitlist\" }, { id: \"cancel\", title: \"✕ Cancel\" }]);\n return;\n }\n await atUpdate(T_USERS, user.id, {\n Bot_State: \"AWAITING_SELECTION\",\n Pending_Pro_ID: found.id,\n Pending_Pro_Phone: found.fields[\"Pro Phone\"],\n Pending_Category: category,\n });\n await sendText(sender, `Great — found you a ${category} expert 👇`);\n await sendConsultantCard(sender, found, category);\n}\n\nasync function phaseSelection(sender: string, user: any, msg: Msg) {\n const f = user.fields;\n const action: string | null = msg.isInteractive ? msg.text : selectionIntent(msg.text);\n\n if (action === \"confirm\" || action === \"keep\") return await initiatePayment(sender, user);\n\n if (action === \"change\") {\n const cat = f.Pending_Category;\n const other = await findPro(cat, f.Pending_Pro_Phone);\n if (other) {\n await atUpdate(T_USERS, user.id, {\n Pending_Pro_ID: other.id, Pending_Pro_Phone: other.fields[\"Pro Phone\"],\n });\n await sendConsultantCard(sender, other, cat);\n return;\n }\n await sendButtons(sender, `No other ${cat} expert is free right now.`, [\n { id: \"keep\", title: \"✅ Keep this one\" },\n { id: \"wl_join2\", title: \"📋 Join waitlist\" },\n { id: \"cancel\", title: \"✕ Cancel\" },\n ]);\n return;\n }\n if (action === \"wl_join2\") {\n await atCreate(T_WAITLIST, {\n User_Phone: sender, Category: f.Pending_Category, Query: \"\", Status: \"Waiting\",\n Joined_At: new Date().toISOString(),\n });\n await atUpdate(T_USERS, user.id, {\n Bot_State: \"POST_SESSION\", Pending_Pro_ID: \"\", Pending_Pro_Phone: \"\", Pending_Category: \"\",\n });\n await sendText(sender, `You're on the waitlist ✅ We'll reach out the moment a ${f.Pending_Category} expert is free.`);\n return;\n }\n if (action === \"cancel\") {\n await atUpdate(T_USERS, user.id, {\n Bot_State: \"AWAITING_QUERY\", Pending_Pro_ID: \"\", Pending_Pro_Phone: \"\", Pending_Category: \"\",\n });\n await sendButtons(sender, \"No problem 👋 Start a new search whenever you like.\", [{ id: \"new_consult\", title: \"🔁 New search\" }]);\n return;\n }\n // Unrecognised — re-show the card buttons.\n await sendButtons(sender, \"Would you like to book this expert?\", [\n { id: \"confirm\", title: \"✅ Book expert\" },\n { id: \"change\", title: \"🔄 See another\" },\n { id: \"cancel\", title: \"✕ Cancel\" },\n ]);\n}\n\n// ── Payment gate ────────────────────────────────────────────────────────────\nasync function initiatePayment(sender: string, user: any) {\n const f = user.fields;\n const proPhone = f.Pending_Pro_Phone;\n const category = f.Pending_Category;\n const pro = await findProByPhone(proPhone);\n const proName = pro?.fields?.[\"Pro Name\"] || \"your expert\";\n const rateRaw = pro?.fields?.[\"Rate\"];\n const amountPaise = rateRaw ? Math.round(parseFloat(rateRaw) * 100) : SESSION_FEE_PAISE;\n const amountRs = amountPaise / 100;\n\n if (!RZP_KEY_ID) { console.log(\"No Razorpay — skipping payment gate\"); await createSession(sender, user); return; }\n\n const link = await createPaymentLink(sender, category, proName, amountPaise);\n if (!link) { console.log(\"Payment link failed — proceeding without payment\"); await createSession(sender, user); return; }\n\n await atUpdate(T_USERS, user.id, {\n Bot_State: \"AWAITING_PAYMENT\",\n Pending_Pro_ID: f.Pending_Pro_ID, Pending_Pro_Phone: proPhone, Pending_Category: category,\n });\n await sendButtons(sender,\n `Almost done! Pay *₹${amountRs}* to confirm your session with *${proName}*.\\n\\n👉 ${link}\\n\\n_Secure payment via Razorpay. We'll connect you the instant it clears._`,\n [{ id: \"cancel\", title: \"✕ Cancel booking\" }]);\n}\n\nasync function phaseAwaitingPayment(sender: string, user: any, msg: Msg) {\n const low = lc(msg.text);\n if ([\"cancel\", \"nahi\", \"no\", \"abort\"].includes(low) || msg.text === \"cancel\") {\n await atUpdate(T_USERS, user.id, {\n Bot_State: \"AWAITING_QUERY\", Pending_Pro_ID: \"\", Pending_Pro_Phone: \"\", Pending_Category: \"\",\n });\n await sendButtons(sender, \"Booking cancelled. No charge made 👋\", [{ id: \"new_consult\", title: \"🔁 New search\" }]);\n return;\n }\n await sendButtons(sender,\n \"⏳ Waiting for your payment to clear. You'll be connected automatically once it does.\",\n [{ id: \"cancel\", title: \"✕ Cancel booking\" }]);\n}\n\n// ── Session creation ─────────────────────────────────────────────────────────\nasync function createSession(sender: string, user: any) {\n const f = user.fields;\n const proPhone = f.Pending_Pro_Phone;\n const proId = f.Pending_Pro_ID;\n const category = f.Pending_Category;\n const query = f.Pending_Query || \"\";\n const pro = await findProByPhone(proPhone);\n const proName = pro?.fields?.[\"Pro Name\"] || \"your expert\";\n\n // Session starts Paused until the pro accepts. buyer_phone denormalized (digits).\n const sessionRec = await atCreate(T_SESSIONS, {\n Users: [user.id],\n Professionals: [proId],\n Status: \"Paused\",\n \"Pro Phone\": digits(proPhone),\n buyer_phone: digits(sender),\n category: category,\n query: query,\n });\n if (!sessionRec) {\n await logError(\"create_session\", \"insert returned null\", sender, \"\");\n await sendText(sender, \"Sorry, we hit a snag connecting you. Our team has been alerted 🙏\");\n await sendText(ADMIN_PHONE, `⚠️ Session create failed for buyer ${sender} / pro ${proPhone}.`);\n return;\n }\n\n await atUpdate(T_USERS, user.id, {\n \"Active Session?\": true, Bot_State: \"IN_SESSION\",\n Pending_Pro_ID: \"\", Pending_Pro_Phone: \"\", Pending_Category: \"\", Pending_Query: \"\",\n });\n await sendText(sender, `⏳ *${proName}* has been notified and will confirm shortly — hang tight!`);\n\n const ok = await sendProTemplate(proPhone, category);\n if (!ok) {\n await logError(\"notify_pro\", \"Template send to pro failed\", digits(proPhone), \"\");\n await sendText(ADMIN_PHONE, `⚠️ Failed to notify ${proName} (${proPhone}) for ${category}. Buyer: ${sender}`);\n await sendText(sender, \"We're having trouble reaching your expert. Our team will connect you manually — sorry for the wait!\");\n }\n}\n\n// ── IN_SESSION (relay buyer → pro) ────────────────────────────────────────────\nasync function phaseInSession(sender: string, user: any, msg: Msg) {\n const session = await findSessionByUserStatus(user.id, \"Active\");\n const paused = await findSessionByUserStatus(user.id, \"Paused\");\n\n if (paused && !session) {\n // Pro hasn't accepted yet. The buyer must be able to bail out while waiting.\n if (msg.isInteractive && (msg.text === \"CLOSE\" || msg.text === \"end_yes\")) {\n return await cancelPendingSession(sender, user, paused);\n }\n if (msg.isInteractive && msg.text === \"end_no\") {\n await sendText(sender, \"👍 Still holding your spot — your expert will join shortly.\");\n return;\n }\n if (isCloseRequest(msg.text)) {\n await sendButtons(sender, \"Your expert hasn't joined yet. Cancel this request?\", [\n { id: \"end_yes\", title: \"✅ Yes, cancel\" },\n { id: \"end_no\", title: \"↩️ Keep waiting\" },\n ]);\n return;\n }\n await sendButtons(sender, \"⏸️ Your expert is getting ready and will join shortly — please hold on.\", [\n { id: \"CLOSE\", title: \"✕ Cancel request\" },\n ]);\n return;\n }\n if (!session) {\n await atUpdate(T_USERS, user.id, { Bot_State: \"POST_SESSION\", \"Active Session?\": false });\n await sendText(sender, \"Your session has ended. Hope it helped!\");\n return;\n }\n\n const proPhone = session.fields[\"Pro Phone\"];\n\n if (msg.isInteractive) {\n if (msg.text === \"end_yes\") {\n const proRec = await findProByPhone(proPhone);\n await closeSession(session, proRec?.fields?.[\"Pro Name\"] || \"your expert\", sender);\n return;\n }\n if (msg.text === \"end_no\") { await sendText(sender, \"👍 Continuing your session.\"); return; }\n }\n\n if (!msg.text) {\n await sendText(sender, \"Only text can be relayed right now — describe it in words (links are fine).\");\n return;\n }\n if (isCloseRequest(msg.text)) {\n await sendButtons(sender, \"End this session?\", [\n { id: \"end_yes\", title: \"✅ Yes, end\" },\n { id: \"end_no\", title: \"↩️ No, continue\" },\n ]);\n return;\n }\n\n if (!proPhone) {\n await sendText(sender, \"⚠️ Couldn't reach your expert. Please contact support.\");\n return;\n }\n await sendText(proPhone, msg.text);\n await logInteraction(session.id, \"Buyer -> Pro\", msg.text);\n}\n\n// ── FEEDBACK ──────────────────────────────────────────────────────────────────\nasync function phaseFeedback(sender: string, user: any, msg: Msg) {\n let rating: number | null = null;\n if (msg.isInteractive && msg.text.startsWith(\"rate_\")) rating = parseInt(msg.text.split(\"_\")[1], 10);\n else rating = ratingFromText(msg.text);\n\n if (!rating) {\n await sendButtons(sender, \"How would you rate your session?\", [\n { id: \"rate_1\", title: \"⭐ Poor\" },\n { id: \"rate_3\", title: \"⭐⭐⭐ Okay\" },\n { id: \"rate_5\", title: \"⭐⭐⭐⭐⭐ Great\" },\n ]);\n return;\n }\n\n const session = await findSessionByUserStatus(user.id, \"Closed\");\n if (session) {\n await atUpdate(T_SESSIONS, session.id, { Rating: rating });\n const pro = await findProByPhone(session.fields[\"Pro Phone\"]);\n if (pro) {\n const old = pro.fields[\"Rating\"] || rating;\n await atUpdate(T_PROS, pro.id, { Rating: Math.round(((old + rating) / 2) * 10) / 10 });\n }\n }\n\n if (rating >= 3) {\n await atUpdate(T_USERS, user.id, { Bot_State: \"POST_SESSION\" });\n await sendText(sender, rating >= 4 ? \"🎉 Glad it helped — thanks for the great rating!\" : \"Thanks for the feedback 🙏\");\n await phasePostSession(sender, user, msg, true);\n return;\n }\n // Low rating → grievance.\n await atUpdate(T_USERS, user.id, { Bot_State: \"GRIEVANCE\" });\n await sendText(sender, \"Really sorry about that 😔 What went wrong? We take this seriously and will look into it.\");\n}\n\n// ── GRIEVANCE ──────────────────────────────────────────────────────────────────\nasync function phaseGrievance(sender: string, user: any, msg: Msg) {\n const complaint = msg.text || \"(no detail provided)\";\n const session = await findSessionByUserStatus(user.id, \"Closed\");\n let proName = \"an expert\";\n if (session) {\n const pro = await findProByPhone(session.fields[\"Pro Phone\"]);\n proName = pro?.fields?.[\"Pro Name\"] || proName;\n }\n await sendText(ADMIN_PHONE, `⚠️ Low-rating complaint\\nBuyer: ${sender}\\nExpert: ${proName}\\n\\n\"${complaint}\"`);\n await atUpdate(T_USERS, user.id, { Bot_State: \"POST_SESSION\" });\n await sendText(sender, \"Thank you — we've logged this and our team will follow up. Quality matters to us.\");\n await phasePostSession(sender, user, msg, true);\n}\n\n// ── POST_SESSION ────────────────────────────────────────────────────────────────\nasync function phasePostSession(sender: string, user: any, msg: Msg, justArrived = false) {\n if (!justArrived && msg.isInteractive) {\n if (msg.text === \"new_consult\") {\n await atUpdate(T_USERS, user.id, {\n Bot_State: \"AWAITING_QUERY\", Pending_Pro_ID: \"\", Pending_Pro_Phone: \"\", Pending_Category: \"\",\n });\n await showCategoryList(sender);\n return;\n }\n if (msg.text === \"support\") {\n await sendText(ADMIN_PHONE, `💬 Support request from ${sender}.`);\n await sendText(sender, \"Our team will reach out shortly 🙏\");\n return;\n }\n if (msg.text === \"refer\") {\n await sendText(sender, \"❤️ Thank you! Share GoodBeetle with a friend:\\nhttps://wa.me/919354052769?text=Hi%20GoodBeetle\");\n return;\n }\n }\n if (justArrived) {\n await sendButtons(sender, \"What next?\", [\n { id: \"new_consult\", title: \"🔁 New session\" },\n { id: \"refer\", title: \"🤝 Refer a friend\" },\n ]);\n }\n}\n\n// ============================================================================\n// GREETING / HELP\n// ============================================================================\nasync function reprompt(sender: string, user: any | null, state: string, name = \"\") {\n if (!user) {\n // First contact via a greeting: create the user now so their next tap is\n // handled as a real selection (prevents the \"welcome twice\" double-step).\n await atCreate(T_USERS, { \"Phone Number\": sender, Name: name, Bot_State: \"AWAITING_QUERY\" });\n await sendText(sender, \"👋 Welcome to *GoodBeetle* — verified experts, on-demand on WhatsApp.\");\n await showCategoryList(sender);\n return;\n }\n switch (state) {\n case \"IN_SESSION\": {\n const session = await findSessionByUserStatus(user.id, \"Active\");\n const paused = await findSessionByUserStatus(user.id, \"Paused\");\n if (!session && paused) {\n // Pro hasn't accepted yet — offer a way out instead of pretending we're connected.\n await sendButtons(sender, \"⏳ Your expert hasn't joined yet — please hold on a moment.\",\n [{ id: \"CLOSE\", title: \"✕ Cancel request\" }]);\n return;\n }\n if (!session && !paused) {\n // Stale state with no session at all — recover gracefully.\n await atUpdate(T_USERS, user.id, { Bot_State: \"AWAITING_QUERY\", \"Active Session?\": false });\n await sendText(sender, \"👋 What do you need help with today?\");\n await showCategoryList(sender);\n return;\n }\n const pro = await findProByPhone(session!.fields[\"Pro Phone\"]);\n const proName = pro?.fields?.[\"Pro Name\"] || \"your expert\";\n await sendButtons(sender, `You're chatting with *${proName}*. Just type to send a message.`,\n [{ id: \"CLOSE\", title: \"✅ End session\" }]);\n return;\n }\n case \"AWAITING_DETAILS\": {\n const cat = user.fields?.Pending_Category;\n await sendText(sender, cat\n ? `You picked *${cat}*. In one line, what do you need help with?`\n : \"In one line, what do you need help with?\");\n return;\n }\n case \"AWAITING_SELECTION\":\n await sendButtons(sender, \"You were choosing an expert. Still interested?\", [\n { id: \"confirm\", title: \"✅ Book expert\" },\n { id: \"change\", title: \"🔄 See another\" },\n { id: \"cancel\", title: \"✕ Cancel\" },\n ]);\n return;\n case \"AWAITING_PAYMENT\":\n await sendButtons(sender, \"⏳ You have a pending payment to finish your booking.\", [{ id: \"cancel\", title: \"✕ Cancel booking\" }]);\n return;\n case \"AWAITING_FEEDBACK\":\n await sendButtons(sender, \"How was your session?\", [\n { id: \"rate_1\", title: \"⭐ Poor\" },\n { id: \"rate_3\", title: \"⭐⭐⭐ Okay\" },\n { id: \"rate_5\", title: \"⭐⭐⭐⭐⭐ Great\" },\n ]);\n return;\n case \"POST_SESSION\":\n await sendButtons(sender, \"What would you like to do?\", [\n { id: \"new_consult\", title: \"🔁 New session\" },\n { id: \"refer\", title: \"🤝 Refer a friend\" },\n ]);\n return;\n default:\n await sendText(sender, \"👋 Hi! What do you need help with?\");\n await showCategoryList(sender);\n return;\n }\n}\n\nasync function contextHelp(sender: string, state: string) {\n const msgs: Record = {\n \"\": \"Pick a category from the menu, or describe what you need.\",\n AWAITING_QUERY: \"Pick a category from the menu, or type what you need and I'll match you.\",\n AWAITING_DETAILS: \"Type one line describing what you need, and I'll find your expert.\",\n AWAITING_SELECTION: \"Tap *Book expert* to confirm, *See another* to browse, or *Cancel* to start over.\",\n AWAITING_PAYMENT: \"Finish the payment to confirm, or tap *Cancel booking* to abort.\",\n IN_SESSION: \"Type to chat with your expert. Tap *End session* when you're done.\",\n AWAITING_FEEDBACK: \"Tap a rating (1–5) to finish.\",\n POST_SESSION: \"Tap *New session* to start another consultation.\",\n };\n await sendText(sender, msgs[state] || msgs[\"\"]);\n}","createdAt",["D",1781035221341],"branchVersion","branchId","74e44356-5ec5-11f1-b611-1607ee4eb77e","id","74e1ada8-5ec5-11f1-b611-1607ee4eb77e","GoodBeetle",["D",1780433758770],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","","imageUrl","9fcdb94f-fd56-4f45-97a6-4e7a36e89a20","pinnedFileId","pinPreview","pinMigrated","screenshotVersion","likeCount",0,"orgId","019e8a1a-da19-73e8-8304-8dfefc6b084b","tursoName","tursoHostname","tursoMeasuredAt","pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_95":94,"_102":53},"org",{"_95":94,"_96":97,"_98":53,"_18":55,"_99":100,"_101":25},"branch",{"_13":84,"_32":85,"_43":42,"_86":44,"_87":-5,"_88":-5,"_89":-5,"_90":-5,"_91":-5,"_92":45,"_93":94},"isOwned",29,"main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","goodbeetle","handle","displayName","goodBeetle","avatar","tier","free","canRestrictVals","profileImageUrl","branchName","adoptOrgId",{"_43":44,"_32":45,"_38":150,"_47":-5,"_48":25,"_49":50,"_51":50,"_52":53,"_54":-5,"_18":55,"_56":-5,"_57":25,"_58":-5,"_59":-5,"_60":61,"_62":63,"_64":-5,"_65":-5,"_66":-5,"_67":-5,"_68":69,"_70":69,"_71":72,"_73":72,"_74":72,"_75":69,"_76":69,"_77":151,"_79":152,"_81":153,"_83":25},"tree",[145],"files",[145],"counts",{"_133":61,"_134":135,"_136":61,"_137":138,"_139":140},"contents",[125],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles",true,"grants","orgs","customDomains",{},{"_43":126,"_32":28,"_30":31,"_127":-5,"_41":42,"_40":14,"_128":25,"_38":129,"_13":130,"_33":34,"_35":37,"_24":25,"_131":-5,"_27":132},"790ea981-d1a8-4c35-89a0-e981cc8ad105","parentId","latest",["D",1781035221341],23,"label",[28],"pulls","branches",1,"forks","envVars",{"_141":143,"_144":61},"connections",{"_141":61,"_142":61},"count","unfilledCount",10,"emptyCount",{"_43":126,"_32":28,"_30":31,"_127":-5,"_41":42,"_40":14,"_128":25,"_38":146,"_13":130,"_33":34,"_35":37,"_24":25,"_131":-5,"_147":148,"_27":149},["D",1781035221341],"children",[],[28],["D",1780433758770],{"_95":94,"_102":53},{"_95":94,"_96":97,"_98":53,"_18":55,"_99":100,"_101":25},{"_13":84,"_32":85,"_43":42,"_86":44,"_87":-5,"_88":-5,"_89":-5,"_90":-5,"_91":-5,"_92":45,"_93":94},"ctx",{"_77":-5,"_122":187,"_188":189,"_190":191,"_192":25,"_193":25,"_194":25,"_195":120,"_196":-5,"_197":-7,"_198":-7,"_199":61,"_200":25,"_201":25,"_202":-5,"_203":25,"_204":25,"_205":25,"_206":-5},"ENV",{"_158":159,"_160":161,"_162":85,"_163":164,"_165":166,"_167":168,"_169":170,"_171":172,"_173":174,"_175":176,"_177":178,"_179":180,"_181":182,"_183":184,"_185":186},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","RENDER_GIT_COMMIT","e87eb04e707cf64e7e532c8e8ec395f209e17f15","RENDER_GIT_BRANCH","POSTHOG_API_TOKEN","phc_nmoyuAkStEZuUp69rYlg1DZgrIt19Gx0Y4Hwf8tGgJP","POSTHOG_API_HOST","https://wart.val.town","WEB_API_TEMPLATE","https://{val}.web.val.run","APP_URL","https://www.val.town","MODULE_URL","https://esm.town","VANITY_WEB_API_TEMPLATE","https://{label}.val.run/","DENOLS_URL","https://lsp.val.town","NODE_ENV","production","CLOUDFLARE_TURNSTILE_SITE_KEY","0x4AAAAAACtaIZJH7s9rBMZ6","GOOGLE_CLIENT_ID","875989696899-jtsqkhlbdv5jrlsk8631p7ipjg3c6o62.apps.googleusercontent.com","STRIPE_PUBLISHABLE_KEY","pk_live_51N2zvWEpZTTLipIkVEwXrUG9AT0yeOOEYxszarZT1jpsZV58Ly6wlg3SltZpHN26CUalOBmUSY7adQRQiSkCZz2500qSXNkf8Y","API_URL","https://api.val.town",[],"preferencesKeybindings","default","preferencesTheme","light","preferencesFixers","preferencesCopilot","preferencesSelectionAi","preferencesCloseBrackets","preferencesChatPanelState","preferencesDprint","preferencesDenofmt","notificationCount","flagDenols","isBusinessOrgMember","businessOrgHandle","isBusinessOrgAdmin","isHigherTownieTier","navCollapsed","currentOrgId"]

Diff · v28