[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_166":167,"_168":169},"routes/_app.x.$handle.$name",{"_95":94,"_33":46,"_103":85,"_28":38,"_13":14,"_104":-5,"_11":105,"_106":107,"_108":109,"_110":111,"_112":113,"_20":-5,"_114":-5,"_115":-5,"_116":27,"_117":118,"_119":25,"_120":-5,"_121":-5,"_122":123},"routes/_app.x.$handle.$name.branch.$branch.version.$version.diff",{"_11":12,"_13":14,"_15":16,"_17":-5,"_18":-5},"project",{"_44":45,"_33":46,"_39":47,"_48":-5,"_49":27,"_50":51,"_52":51,"_53":38,"_54":-5,"_18":55,"_56":-5,"_57":27,"_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":27},"version",19,"changes",[19],"aiChatInfo","userId",{"_20":21,"_22":23,"_24":25,"_26":27,"_28":29,"_30":29},"file",{"_31":32,"_33":29,"_35":36,"_37":38,"_39":40,"_41":14,"_42":43,"_24":27},"previous",{"_31":32,"_33":34,"_35":36,"_37":38},"deleted",true,"deletedHere",false,"path","supabase_db.ts","latestPath","fileId","24f99072-60f9-11f1-9c37-1607ee4eb77e","name","new-file-9073.ts","fileType","script","content","","createdAt",["D",1780675880339],"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":38},"org",{"_95":94,"_96":97,"_98":38,"_18":55,"_99":100,"_101":27},"branch",{"_13":84,"_33":85,"_44":43,"_86":45,"_87":-5,"_88":-5,"_89":-5,"_90":-5,"_91":-5,"_92":46,"_93":94},"isOwned",29,"main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","goodbeetle","handle","displayName","goodBeetle","avatar","tier","free","canRestrictVals","profileImageUrl","branchName","adoptOrgId",{"_44":45,"_33":46,"_39":162,"_48":-5,"_49":27,"_50":51,"_52":51,"_53":38,"_54":-5,"_18":55,"_56":-5,"_57":27,"_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":163,"_79":164,"_81":165,"_83":27},"tree",[153,154],"files",[153,154],"counts",{"_142":61,"_143":130,"_144":61,"_145":146,"_147":148},"contents",[124,125],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},{"_44":133,"_33":134,"_31":135,"_127":-5,"_42":43,"_41":136,"_128":27,"_39":137,"_13":138,"_35":139,"_37":140,"_24":27,"_131":-5,"_28":141},{"_44":126,"_33":29,"_31":32,"_127":-5,"_42":43,"_41":14,"_128":27,"_39":129,"_13":130,"_35":36,"_37":38,"_24":27,"_131":-5,"_28":132},"0260815e-cb5e-45a0-b861-8ae6eafd03e7","parentId","latest",["D",1780675880339],1,"label",[29],"cab3a112-5f3a-11f1-a15b-1607ee4eb77e","main.ts","74eb91e2-5ec5-11f1-b611-1607ee4eb77e",17,["D",1780484153859],16,"http","// ============================================================================\n// GoodBeetle WhatsApp Consultation Bot — VAL TOWN version (HTTP val)\n// ----------------------------------------------------------------------------\n// Create this as an *HTTP* val. Val Town gives it a public URL like:\n// https://goodbeetle--.web.val.run\n// That URL is what you paste into Meta as the webhook Callback URL.\n//\n// SECRETS — set these in Val Town → Settings → Environment Variables:\n// WHATSAPP_TOKEN = Meta permanent System User token\n// AIRTABLE_TOKEN = Airtable Personal Access Token\n// OPENAI_KEY = OpenAI API key\n// META_VERIFY_TOKEN = any word YOU choose (same word typed in Meta)\n// RAZORPAY_KEY_ID = Razorpay Key ID (live or test)\n// RAZORPAY_KEY_SECRET= Razorpay Key Secret\n// ============================================================================\n\n// ---- Secrets ---------------------------------------------------------------\nconst WA_TOKEN = Deno.env.get(\"WHATSAPP_TOKEN\")!;\nconst AT_TOKEN = Deno.env.get(\"AIRTABLE_TOKEN\")!;\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\") || \"\";\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 in paise — change as needed\n\nconst BASE_ID = \"appYfPdJ12XYHylJk\";\nconst T_USERS = \"tblbyHfdKW0xODHsD\";\nconst T_PROS = \"tblRG7yeQbtV3ZSw5\";\nconst T_SESSIONS = \"tblXfb0CWKowiRVRu\";\nconst T_WAITLIST = \"tblNN60JP8biLyZD8\";\nconst T_LOGS = \"tblZQPY4cVvLOax7G\";\nconst T_ERRORS = \"tblTIjTvx2uNu5tzn\";\n\nconst CATEGORIES = [\n \"Legal\",\n \"Tax & GST\",\n \"Startup & Compliance\",\n \"Tech\",\n \"Fitness\",\n \"Nutrition\",\n \"HR & Labour\",\n \"Marketing\",\n \"Product\",\n \"Astrology\",\n \"Vastu\",\n];\nconst CAT_BY_ID: Record = {\n legal: \"Legal\",\n tax: \"Tax & GST\",\n startup: \"Startup & Compliance\",\n tech: \"Tech\",\n fitness: \"Fitness\",\n nutrition: \"Nutrition\",\n hr: \"HR & Labour\",\n marketing: \"Marketing\",\n product: \"Product\",\n astrology: \"Astrology\",\n vastu: \"Vastu\",\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)\n if (req.method === \"GET\") {\n const mode = url.searchParams.get(\"hub.mode\");\n const token = url.searchParams.get(\"hub.verify_token\");\n const challenge = url.searchParams.get(\"hub.challenge\");\n if (mode === \"subscribe\" && token === VERIFY_TOKEN) {\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 message (POST)\n if (req.method === \"POST\") {\n // Razorpay webhook (payment confirmation)\n const ct = req.headers.get(\"content-type\") || \"\";\n if (ct.includes(\"application/json\") && url.pathname.includes(\"/payment\")) {\n let body: any = {};\n try {\n body = await req.json();\n } catch (_) {}\n try {\n await handlePaymentWebhook(body);\n } catch (e: any) {\n console.error(\"payment webhook error:\", e?.message);\n }\n return new Response(\"OK\", { status: 200 });\n }\n\n // WhatsApp message\n let body: any = {};\n try {\n body = await req.json();\n } catch (_) {}\n console.log(\"RAW INCOMING:\", JSON.stringify(body).slice(0, 500));\n try {\n await handleMessage(body);\n } catch (e: any) {\n console.error(\"handleMessage error:\", e?.message || e, e?.stack);\n }\n return new Response(\"EVENT_RECEIVED\", { status: 200 });\n }\n\n return new Response(\"OK\", { status: 200 });\n}\n\n// ============================================================================\n// WHATSAPP SEND HELPERS — all log errors\n// ============================================================================\nasync function waPost(payload: any): Promise {\n try {\n const r = await fetch(WA_URL, {\n method: \"POST\",\n headers: {\n Authorization: `Bearer ${WA_TOKEN}`,\n \"Content-Type\": \"application/json\",\n },\n body: JSON.stringify(payload),\n });\n const d = await r.json();\n if (!r.ok) {\n console.error(\"waPost FAILED\", r.status, JSON.stringify(d));\n return false;\n }\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 console.log(`sendText → ${to}: ${text.slice(0, 80)}`);\n return waPost({\n messaging_product: \"whatsapp\",\n to,\n type: \"text\",\n text: { body: text },\n });\n}\n\nasync function sendButtons(\n to: string,\n body: string,\n buttons: { id: string; title: string }[],\n): Promise {\n console.log(`sendButtons → ${to}: ${body.slice(0, 60)}`);\n return waPost({\n messaging_product: \"whatsapp\",\n to,\n type: \"interactive\",\n interactive: {\n type: \"button\",\n body: { text: body },\n action: {\n buttons: buttons.map((b) => ({\n type: \"reply\",\n reply: { id: b.id, title: b.title },\n })),\n },\n },\n });\n}\n\nasync function sendList(\n to: string,\n body: string,\n buttonLabel: string,\n rows: { id: string; title: string }[],\n): Promise {\n console.log(`sendList → ${to}: ${body.slice(0, 60)}`);\n return waPost({\n messaging_product: \"whatsapp\",\n to,\n type: \"interactive\",\n interactive: {\n type: \"list\",\n body: { text: body },\n action: {\n button: buttonLabel,\n sections: [{ title: \"Categories\", rows }],\n },\n },\n });\n}\n\nasync function sendProTemplate(to: string, category: string): Promise {\n console.log(`sendProTemplate → ${to}, category: ${category}`);\n const payload = {\n messaging_product: \"whatsapp\",\n to,\n type: \"template\",\n template: {\n name: \"professional_acceptance\",\n language: { code: \"en\" },\n components: [{\n type: \"body\",\n parameters: [{ type: \"text\", text: category }],\n }],\n },\n };\n const r = await fetch(WA_URL, {\n method: \"POST\",\n headers: {\n Authorization: `Bearer ${WA_TOKEN}`,\n \"Content-Type\": \"application/json\",\n },\n body: JSON.stringify(payload),\n });\n const d = await r.json();\n if (!r.ok) console.error(\"sendProTemplate FAILED:\", JSON.stringify(d));\n else console.log(\"sendProTemplate OK:\", JSON.stringify(d));\n return r.ok;\n}\n\n// ============================================================================\n// AIRTABLE HELPERS\n// ============================================================================\nasync function atSearch(table: string, formula: string): Promise {\n const u =\n `https://api.airtable.com/v0/${BASE_ID}/${table}?maxRecords=1&filterByFormula=${\n encodeURIComponent(formula)\n }`;\n const r = await fetch(u, {\n headers: { Authorization: `Bearer ${AT_TOKEN}` },\n });\n const d = await r.json();\n if (!r.ok) {\n console.error(\"atSearch FAILED\", table, formula, JSON.stringify(d));\n return null;\n }\n return d.records && d.records.length ? d.records[0] : null;\n}\nasync function atCreate(table: string, fields: any): Promise {\n const r = await fetch(`https://api.airtable.com/v0/${BASE_ID}/${table}`, {\n method: \"POST\",\n headers: {\n Authorization: `Bearer ${AT_TOKEN}`,\n \"Content-Type\": \"application/json\",\n },\n body: JSON.stringify({ fields }),\n });\n const d = await r.json();\n if (!r.ok) console.error(\"atCreate FAILED\", table, JSON.stringify(d));\n return d;\n}\nasync function atUpdate(table: string, id: string, fields: any): Promise {\n const r = await fetch(\n `https://api.airtable.com/v0/${BASE_ID}/${table}/${id}`,\n {\n method: \"PATCH\",\n headers: {\n Authorization: `Bearer ${AT_TOKEN}`,\n \"Content-Type\": \"application/json\",\n },\n body: JSON.stringify({ fields }),\n },\n );\n const d = await r.json();\n if (!r.ok) console.error(\"atUpdate FAILED\", table, id, JSON.stringify(d));\n return d;\n}\n// Fetch full record by ID (needed for lookup fields)\nasync function atGet(table: string, id: string): Promise {\n const r = await fetch(\n `https://api.airtable.com/v0/${BASE_ID}/${table}/${id}`,\n {\n headers: { Authorization: `Bearer ${AT_TOKEN}` },\n },\n );\n const d = await r.json();\n if (!r.ok) {\n console.error(\"atGet FAILED\", table, id, JSON.stringify(d));\n return null;\n }\n return d;\n}\n\n// Resolve buyer phone from session (lookup fields return record IDs, not values)\nasync function getBuyerPhone(session: any): Promise {\n const userLinks: string[] = session?.fields?.Users || [];\n if (!userLinks.length) {\n console.log(\"getBuyerPhone: no user links on session\");\n return null;\n }\n const buyerRec = await atGet(T_USERS, userLinks[0]);\n const phone = buyerRec?.fields?.[\"Phone Number\"] || null;\n console.log(\"getBuyerPhone:\", phone);\n return phone;\n}\n\nasync function logInteraction(\n sessionId: string,\n direction: string,\n content: string,\n) {\n try {\n await atCreate(T_LOGS, {\n Sessions: [sessionId],\n Direction: direction,\n Content: content,\n Timestamp: new Date().toISOString(),\n });\n } catch (_) {}\n}\nasync function logError(\n node: string,\n msg: string,\n sender: string,\n raw: string,\n) {\n try {\n await atCreate(T_ERRORS, {\n Workflow: \"GoodBeetle Bot\",\n Failed_Node: node,\n Error_Message: msg,\n Timestamp: new Date().toISOString(),\n Error_Type: \"Runtime\",\n Sender_Phone: sender,\n Raw_Message: raw,\n });\n } catch (_) {}\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: {\n Authorization: `Bearer ${OPENAI_KEY}`,\n \"Content-Type\": \"application/json\",\n },\n body: JSON.stringify({\n model: \"gpt-4o-mini\",\n temperature: 0,\n messages: [{ role: \"system\", content: sys }, {\n role: \"user\",\n content: query,\n }],\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 LINK\n// ============================================================================\nasync function createPaymentLink(\n buyerPhone: string,\n category: string,\n proName: string,\n amountPaise: number,\n): Promise {\n if (!RZP_KEY_ID || !RZP_SECRET) {\n console.log(\"Razorpay keys not set — skipping payment\");\n return null;\n }\n const auth = btoa(`${RZP_KEY_ID}:${RZP_SECRET}`);\n const payload = {\n amount: amountPaise,\n currency: \"INR\",\n description: `GoodBeetle: ${category} consultation with ${proName}`,\n customer: { contact: `+${buyerPhone}` },\n notify: { whatsapp: false, sms: false, email: false },\n reminder_enable: false,\n callback_url:\n `https://goodbeetle--74eb91e25ec511f1b6111607ee4eb77e.web.val.run/payment`,\n callback_method: \"get\",\n notes: { buyer_phone: buyerPhone, category },\n };\n try {\n const r = await fetch(\"https://api.razorpay.com/v1/payment_links\", {\n method: \"POST\",\n headers: {\n Authorization: `Basic ${auth}`,\n \"Content-Type\": \"application/json\",\n },\n body: JSON.stringify(payload),\n });\n const d = await r.json();\n if (!r.ok) {\n console.error(\"Razorpay createPaymentLink FAILED:\", JSON.stringify(d));\n return null;\n }\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 verifyRazorpayPayment(paymentLinkId: string): Promise {\n if (!RZP_KEY_ID || !RZP_SECRET) return false;\n const auth = btoa(`${RZP_KEY_ID}:${RZP_SECRET}`);\n try {\n const r = await fetch(\n `https://api.razorpay.com/v1/payment_links/${paymentLinkId}`,\n {\n headers: { Authorization: `Basic ${auth}` },\n },\n );\n const d = await r.json();\n return d.status === \"paid\";\n } catch (e: any) {\n console.error(\"verifyRazorpayPayment error:\", e?.message);\n return false;\n }\n}\n\n// Handle Razorpay payment callback (GET /payment?razorpay_payment_link_id=...&razorpay_payment_link_status=paid)\nasync function handlePaymentWebhook(body: any) {\n // Also handle as GET params passed into POST body by our callback\n const linkId = body?.razorpay_payment_link_id;\n const status = body?.razorpay_payment_link_status;\n const buyerPhone = body?.notes?.buyer_phone ||\n body?.razorpay_payment_link_reference_id;\n if (!linkId) return;\n console.log(\n \"Payment callback linkId:\",\n linkId,\n \"status:\",\n status,\n \"buyer:\",\n buyerPhone,\n );\n if (status !== \"paid\") return;\n if (!buyerPhone) return;\n\n // Look up buyer and trigger session creation\n const user = await atSearch(T_USERS, `{Phone Number}=\"${buyerPhone}\"`);\n if (!user) {\n console.error(\"Payment callback: user not found for phone\", buyerPhone);\n return;\n }\n const state = user.fields?.Bot_State;\n if (state !== \"AWAITING_PAYMENT\") {\n console.log(\n \"Payment callback: user not in AWAITING_PAYMENT state, ignoring\",\n );\n return;\n }\n\n await atUpdate(T_USERS, user.id, { Bot_State: \"IN_SESSION\" }); // temp to prevent double-trigger\n await sendText(\n buyerPhone,\n \"✅ Payment received! Connecting you with your expert now...\",\n );\n await createSession(buyerPhone, user);\n}\n\n// ============================================================================\n// UI HELPERS\n// ============================================================================\nasync function showCategoryList(to: string, exclude: string[] = []) {\n const all = [\n { id: \"legal\", title: \"⚖️ Legal\" },\n { id: \"tax\", title: \"💰 Tax & GST\" },\n { id: \"startup\", title: \"🚀 Startup & Compliance\" },\n { id: \"tech\", title: \"💻 Tech\" },\n { id: \"fitness\", title: \"💪 Fitness\" },\n { id: \"nutrition\", title: \"🍎 Nutrition\" },\n { id: \"hr\", title: \"🏢 HR & Labour\" },\n { id: \"marketing\", title: \"📣 Marketing\" },\n { id: \"product\", title: \"🛠️ Product\" },\n { id: \"astrology\", title: \"🔮 Astrology\" },\n { id: \"vastu\", title: \"🏠 Vastu\" },\n { id: \"other\", title: \"💬 Other / Not listed\" },\n ].filter((r) => !exclude.includes(CAT_BY_ID[r.id]));\n await sendList(\n to,\n \"What do you need help with today?\",\n \"Pick a category\",\n all,\n );\n}\n\nasync function findPro(\n category: string,\n excludePhone?: string,\n): Promise {\n let f =\n `AND(FIND(\"${category}\", ARRAYJOIN({Category (from Specialization)}, \",\")), {Availability}=TRUE())`;\n if (excludePhone) {\n f =\n `AND(FIND(\"${category}\", ARRAYJOIN({Category (from Specialization)}, \",\")), {Availability}=TRUE(), NOT({Pro Phone}=\"${excludePhone}\"))`;\n }\n return atSearch(T_PROS, f);\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\"]}/session` : \"₹499/session\";\n const body = `*${\n f[\"Pro Name\"]\n }*\\n${category} Expert\\n${rating} • ${rate}\\n✅ Available now`;\n await sendButtons(to, body, [\n { id: \"confirm\", title: \"✅ Book this 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;\n type: string;\n text: string;\n title: string;\n isInteractive: boolean;\n 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 = m.from;\n const name = value?.contacts?.[0]?.profile?.name || \"\";\n if (m.type === \"text\") {\n return {\n sender,\n type: \"text\",\n text: (m.text?.body || \"\").trim(),\n title: \"\",\n isInteractive: false,\n name,\n };\n }\n if (m.type === \"interactive\") {\n const btnReply = m.interactive?.button_reply;\n const listReply = m.interactive?.list_reply;\n const id = btnReply?.id || listReply?.id || \"\";\n const title = btnReply?.title || listReply?.title || \"\";\n return {\n sender,\n type: \"interactive\",\n text: id || title,\n title,\n isInteractive: true,\n name,\n };\n }\n // Unsupported type (image, sticker, etc.) — treat as empty text so state machine can respond\n return {\n sender,\n type: m.type,\n text: \"\",\n title: \"\",\n isInteractive: false,\n name,\n };\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\nfunction selectionIntent(t: string): \"confirm\" | \"cancel\" | \"change\" | null {\n const s = lc(t);\n if (\n [\"yes\", \"ok\", \"okay\", \"confirm\", \"sure\", \"haan\", \"ha\", \"book\"].includes(s)\n ) return \"confirm\";\n if ([\"no\", \"cancel\", \"nahi\", \"nope\"].includes(s)) return \"cancel\";\n if ([\"change\", \"other\", \"next\", \"aur\", \"different\", \"someone\"].includes(s)) {\n return \"change\";\n }\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 — good enough)\nconst recent = new Map();\n\n// ============================================================================\n// PRO PATH\n// ============================================================================\nasync function handleProPath(pro: any, msg: Msg) {\n const proPhonePlus = \"+\" + msg.sender;\n const session = await atSearch(\n T_SESSIONS,\n `AND({Pro Phone}=\"${proPhonePlus}\", {Status}=\"Active\")`,\n );\n const paused = await atSearch(\n T_SESSIONS,\n `AND({Pro Phone}=\"${proPhonePlus}\", {Status}=\"Paused\")`,\n );\n const cmd = msg.text.trim().toUpperCase();\n const titleLower = (msg.title || msg.text).trim().toLowerCase();\n\n console.log(\n `handleProPath: cmd=\"${cmd}\" title=\"${titleLower}\" session=${session?.id} paused=${paused?.id}`,\n );\n\n // --- Template button responses ---\n if (titleLower === \"let's start\" && paused) {\n await atUpdate(T_SESSIONS, paused.id, { Status: \"Active\" });\n await sendText(\n msg.sender,\n \"✅ Session started!\\n\\nYou can now chat directly with your client. Type *CLOSE* to end the session, *PAUSE* to put it on hold.\",\n );\n const buyer = await getBuyerPhone(paused);\n if (buyer) {\n await sendText(\n buyer,\n \"✅ Your expert has joined! Go ahead and share your question.\",\n );\n }\n return;\n }\n if (titleLower === \"not available\" && paused) {\n await atUpdate(T_SESSIONS, paused.id, { Status: \"Closed\" });\n await sendText(\n msg.sender,\n \"Got it — session declined. You won't be disturbed for this request.\",\n );\n const buyer = await getBuyerPhone(paused);\n if (buyer) {\n const buyerUser = await atSearch(T_USERS, `{Phone Number}=\"${buyer}\"`);\n const cat = buyerUser?.fields?.Pending_Category || \"\";\n const altPro = cat ? await findPro(cat, proPhonePlus) : null;\n if (altPro) {\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(\n buyer,\n \"That expert isn't available right now. Here's another option:\",\n );\n await sendConsultantCard(buyer, altPro, cat);\n } else {\n // Refund handling would go here in the future\n await atUpdate(T_USERS, buyerUser.id, {\n Bot_State: \"POST_SESSION\",\n \"Active Session?\": false,\n });\n await atCreate(T_WAITLIST, {\n User_Phone: buyer,\n Category: cat,\n Query: \"\",\n Status: \"Waiting\",\n Joined_At: new Date().toISOString(),\n });\n await sendText(\n buyer,\n \"Sorry, no other experts are available right now. We've added you to the waitlist and will WhatsApp you as soon as someone is free.\\n\\nIf you paid, a refund will be processed within 24 hours.\",\n );\n }\n }\n return;\n }\n if (titleLower === \"please wait\" && paused) {\n await sendText(\n msg.sender,\n \"⏸️ Okay, client is on hold. Send *RESUME* when you're ready.\",\n );\n const buyer = await getBuyerPhone(paused);\n if (buyer) {\n await sendText(\n buyer,\n \"⏸️ Your expert is finishing something. They'll be with you shortly — please hold on.\",\n );\n }\n return;\n }\n\n if (cmd === \"HELP\") {\n await sendText(\n msg.sender,\n \"Session commands:\\n• *CLOSE* — end the session\\n• *PAUSE* — put on hold\\n• *RESUME* — continue after pause\",\n );\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(\n msg.sender,\n \"No active client session found. You'll be notified when a client books you.\",\n );\n return;\n }\n if (!session && paused) {\n await sendText(\n msg.sender,\n \"Session is on hold. Send *RESUME* to continue.\",\n );\n return;\n }\n\n const buyerPhone = await getBuyerPhone(session!);\n if (cmd === \"CLOSE\") {\n await closeSession(session!, pro.fields[\"Pro Name\"], buyerPhone);\n return;\n }\n if (cmd === \"PAUSE\") {\n await atUpdate(T_SESSIONS, session!.id, { Status: \"Paused\" });\n await sendText(msg.sender, \"⏸️ Session paused. Send *RESUME* to continue.\");\n if (buyerPhone) {\n await sendText(\n buyerPhone,\n \"⏸️ Your expert has paused briefly. They'll be back soon.\",\n );\n }\n return;\n }\n\n if (!msg.text) {\n await sendText(\n msg.sender,\n \"Only text messages can be relayed right now. Share a link or describe it in words.\",\n );\n return;\n }\n\n // Relay message to buyer\n if (buyerPhone) {\n await sendText(buyerPhone, msg.text);\n await logInteraction(session!.id, \"Pro -> Buyer\", msg.text);\n } else {\n console.error(\n \"handleProPath: couldn't resolve buyer phone for session\",\n session!.id,\n );\n await sendText(\n msg.sender,\n \"⚠️ Could not relay — unable to find client's phone. Contact support.\",\n );\n }\n}\n\n// ============================================================================\n// SESSION CLOSE + FEEDBACK\n// ============================================================================\nasync function closeSession(\n session: any,\n proName: string,\n buyerPhone: string | null,\n) {\n await atUpdate(T_SESSIONS, session.id, { Status: \"Closed\" });\n const proPhone = session.fields[\"Pro Phone\"];\n if (proPhone) {\n await sendText(\n proPhone.replace(\"+\", \"\"),\n `Session closed ✅\\n\\nThanks for your time, ${proName}!`,\n );\n }\n if (buyerPhone) {\n const user = await atSearch(T_USERS, `{Phone Number}=\"${buyerPhone}\"`);\n if (user) {\n await atUpdate(T_USERS, user.id, {\n \"Active Session?\": false,\n Bot_State: \"AWAITING_FEEDBACK\",\n });\n }\n await sendButtons(\n buyerPhone,\n `Your session with *${proName}* has ended.\\n\\nHow would you rate it?`,\n [\n { id: \"rate_1\", title: \"⭐ 1 — Poor\" },\n { id: \"rate_3\", title: \"⭐⭐⭐ 3 — Okay\" },\n { id: \"rate_5\", title: \"⭐⭐⭐⭐⭐ 5 — Great\" },\n ],\n );\n }\n}\n\n// ============================================================================\n// MAIN MESSAGE HANDLER\n// ============================================================================\nasync function handleMessage(body: any) {\n const msg = parse(body);\n if (!msg) {\n console.log(\"No parseable message — likely a status update, skipping\");\n return;\n }\n\n // Dedupe (same 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) {\n console.log(\"Deduped:\", key);\n return;\n }\n recent.set(key, now);\n if (recent.size > 500) recent.clear();\n\n const sender = msg.sender;\n console.log(\n `MSG from ${sender}: type=${msg.type} text=\"${msg.text}\" title=\"${msg.title}\"`,\n );\n\n try {\n const pro = await atSearch(T_PROS, `{Pro Phone}=\"+${sender}\"`);\n let user = await atSearch(T_USERS, `{Phone Number}=\"${sender}\"`);\n const state: string = user?.fields?.Bot_State || \"\";\n\n // ── Pro routing ────────────────────────────────────────────────────────\n if (pro) {\n const proPhonePlus = \"+\" + sender;\n const hasActiveSession = await atSearch(\n T_SESSIONS,\n `OR(AND({Pro Phone}=\"${proPhonePlus}\", {Status}=\"Active\"), AND({Pro Phone}=\"${proPhonePlus}\", {Status}=\"Paused\"))`,\n );\n // If pro has an active/paused client session, or sends a relay command, route to pro path\n if (hasActiveSession || isRelayCmd(msg.text)) {\n return await handleProPath(pro, msg);\n }\n // If pro is mid-disambiguation flow\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) {\n user = await atCreate(T_USERS, {\n \"Phone Number\": sender,\n Name: msg.name,\n Bot_State: \"AWAITING_QUERY\",\n });\n } else {await atUpdate(T_USERS, user.id, {\n Bot_State: \"AWAITING_QUERY\",\n });}\n await sendList(\n sender,\n \"What do you need help with today?\",\n \"Pick a category\",\n [\n { id: \"legal\", title: \"⚖️ Legal\" },\n { id: \"tax\", title: \"💰 Tax & GST\" },\n { id: \"startup\", title: \"🚀 Startup & Compliance\" },\n { id: \"tech\", title: \"💻 Tech\" },\n { id: \"fitness\", title: \"💪 Fitness\" },\n { id: \"nutrition\", title: \"🍎 Nutrition\" },\n { id: \"hr\", title: \"🏢 HR & Labour\" },\n { id: \"marketing\", title: \"📣 Marketing\" },\n { id: \"product\", title: \"🛠️ Product\" },\n { id: \"astrology\", title: \"🔮 Astrology\" },\n { id: \"vastu\", title: \"🏠 Vastu\" },\n { id: \"other\", title: \"💬 Other / Not listed\" },\n ].filter((r) =>\n !((pro.fields[\"Category (from Specialization)\"] || []).includes(\n CAT_BY_ID[r.id],\n ))\n ),\n );\n return;\n }\n // Re-show the ambiguity prompt if unrecognised\n await sendButtons(\n sender,\n \"Are you here as a professional (for a client session) or as a user seeking advice?\",\n [{ id: \"as_pro\", title: \"👔 I have a client\" }, {\n id: \"as_buyer\",\n title: \"🙋 I need advice\",\n }],\n );\n return;\n }\n // Pro with no active session and not in any flow — ask intent\n if (!user) {\n user = await atCreate(T_USERS, {\n \"Phone Number\": sender,\n Name: msg.name,\n Bot_State: \"PRO_OR_BUYER_PENDING\",\n });\n } else {await atUpdate(T_USERS, user.id, {\n Bot_State: \"PRO_OR_BUYER_PENDING\",\n });}\n await sendButtons(\n sender,\n \"Hey! Are you here as a professional (waiting for a client) or as a user (need advice yourself)?\",\n [{ id: \"as_pro\", title: \"👔 I have a client\" }, {\n id: \"as_buyer\",\n title: \"🙋 I need advice\",\n }],\n );\n return;\n }\n\n // ── Global commands ────────────────────────────────────────────────────\n const low = lc(msg.text);\n if (\n !msg.isInteractive &&\n [\"menu\", \"start\", \"hi\", \"hello\", \"hey\"].includes(low)\n ) {\n return await reprompt(sender, user, state);\n }\n if (!msg.isInteractive && low === \"help\") {\n return await contextHelp(sender, state);\n }\n\n // ── New buyer ──────────────────────────────────────────────────────────\n if (!user) {\n const name = msg.name || \"there\";\n user = await atCreate(T_USERS, {\n \"Phone Number\": sender,\n Name: msg.name,\n Bot_State: \"AWAITING_QUERY\",\n });\n await sendText(\n sender,\n `👋 Welcome to *GoodBeetle*, ${name}!\\n\\nWe connect you with verified experts for quick, affordable consultations — right here on WhatsApp.\\n\\nWhat do you need help with today?`,\n );\n await showCategoryList(sender);\n return;\n }\n\n // ── State router ───────────────────────────────────────────────────────\n switch (state) {\n case \"\":\n case \"AWAITING_QUERY\":\n return await phaseAwaitingQuery(sender, user, msg, pro);\n case \"AWAITING_SELECTION\":\n return await phaseSelection(sender, user, msg);\n case \"AWAITING_PAYMENT\":\n return await phaseAwaitingPayment(sender, user, msg);\n case \"IN_SESSION\":\n return await phaseInSession(sender, user, msg);\n case \"AWAITING_FEEDBACK\":\n return await phaseFeedback(sender, user, msg);\n case \"GRIEVANCE\":\n return await phaseGrievance(sender, user, msg);\n case \"POST_SESSION\":\n 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(\n \"handleMessage\",\n String(e?.message || e),\n sender,\n JSON.stringify(body).slice(0, 1000),\n );\n }\n}\n\n// ============================================================================\n// STATE HANDLERS\n// ============================================================================\n\nasync function phaseAwaitingQuery(\n sender: string,\n user: any,\n msg: Msg,\n pro: any,\n) {\n // Category selected from list\n if (msg.isInteractive) {\n if (msg.text === \"other\") {\n await atUpdate(T_USERS, user.id, {\n Pending_Category: \"UNKNOWN\",\n Bot_State: \"AWAITING_QUERY\",\n });\n await sendText(\n sender,\n \"No problem! Briefly describe what kind of expert you're looking for and I'll try to find the right match.\",\n );\n return;\n }\n const category = CAT_BY_ID[msg.text];\n if (category) return await tryFindPro(sender, user, category, pro);\n // Waitlist choices\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 UNKNOWN category\n if (\n user.fields?.Pending_Category === \"UNKNOWN\" && msg.type === \"text\" &&\n msg.text\n ) {\n const cat2 = await classify(msg.text);\n if (cat2 !== \"NO_MATCH\") {\n await atUpdate(T_USERS, user.id, { Pending_Category: cat2 });\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(\n sender,\n \"We don't have that category yet — but we're growing fast! Want to join the waitlist?\",\n [\n { id: \"wl_join\", title: \"✅ Join waitlist\" },\n { id: \"wl_diff\", title: \"🔄 Try a different category\" },\n { id: \"wl_never\", title: \"✕ Never mind\" },\n ],\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(\n sender,\n \"I'm not sure which category fits that. Pick one from the list:\",\n );\n await showCategoryList(sender);\n return;\n }\n await atUpdate(T_USERS, user.id, { Pending_Category: cat });\n return await tryFindPro(sender, user, cat, pro, msg.text);\n }\n\n await showCategoryList(sender);\n}\n\nasync function unknownWaitlistChoice(\n sender: string,\n user: any,\n choice: string,\n) {\n if (choice === \"wl_join\") {\n const desc = user.fields?.Pending_Pro_ID || \"your request\";\n await atCreate(T_WAITLIST, {\n User_Phone: sender,\n Category: \"UNKNOWN\",\n Query: desc,\n Status: \"Waiting\",\n Joined_At: new Date().toISOString(),\n });\n await atUpdate(T_USERS, user.id, {\n Bot_State: \"POST_SESSION\",\n Pending_Category: \"\",\n Pending_Pro_ID: \"\",\n });\n await sendText(\n sender,\n `Done ✅\\n\\nWe'll WhatsApp you as soon as an expert is available. You'll be first in line.`,\n );\n return;\n }\n if (choice === \"wl_diff\") {\n await atUpdate(T_USERS, user.id, {\n Pending_Category: \"\",\n Pending_Pro_ID: \"\",\n });\n await showCategoryList(sender);\n return;\n }\n await atUpdate(T_USERS, user.id, {\n Bot_State: \"AWAITING_QUERY\",\n Pending_Category: \"\",\n Pending_Pro_ID: \"\",\n });\n await sendText(sender, \"No problem. Come back anytime 👋\");\n}\n\nasync function tryFindPro(\n sender: string,\n user: any,\n category: string,\n pro: any,\n queryText?: string,\n) {\n // Don't match pros with 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(\n sender,\n `You're listed as a ${category} expert yourself! Pick a different category for your own query.`,\n );\n await showCategoryList(sender, own);\n return;\n }\n }\n if (queryText) {\n await atUpdate(T_USERS, user.id, { Pending_Category: category });\n }\n\n const found = await findPro(category);\n if (!found) {\n await atUpdate(T_USERS, user.id, {\n Pending_Category: category,\n Pending_Pro_Phone: \"WAIT\",\n });\n await sendText(\n sender,\n `All our ${category} experts are with other clients right now.\\n\\nJoin the waitlist and we'll WhatsApp you the moment someone is free.`,\n );\n await sendButtons(sender, \" \", [\n { id: \"wl_join2\", title: \"✅ Join waitlist\" },\n { id: \"cancel\", title: \"✕ Cancel\" },\n ]);\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 sendConsultantCard(sender, found, category);\n}\n\nasync function phaseSelection(sender: string, user: any, msg: Msg) {\n const f = user.fields;\n let action: string | null = msg.isInteractive\n ? msg.text\n : selectionIntent(msg.text);\n\n if (action === \"confirm\" || action === \"keep\") {\n // Payment gate\n 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,\n Pending_Pro_Phone: other.fields[\"Pro Phone\"],\n });\n await sendConsultantCard(sender, other, cat);\n return;\n }\n await sendButtons(\n sender,\n `No other ${cat} expert is available right now.`,\n [\n { id: \"keep\", title: \"✅ Keep current expert\" },\n { id: \"wl_join2\", title: \"📋 Join waitlist\" },\n { id: \"cancel\", title: \"✕ Cancel\" },\n ],\n );\n return;\n }\n if (action === \"wl_join2\") {\n await atCreate(T_WAITLIST, {\n User_Phone: sender,\n Category: f.Pending_Category,\n Query: \"\",\n Status: \"Waiting\",\n Joined_At: new Date().toISOString(),\n });\n await atUpdate(T_USERS, user.id, {\n Bot_State: \"POST_SESSION\",\n Pending_Pro_ID: \"\",\n Pending_Pro_Phone: \"\",\n Pending_Category: \"\",\n });\n await sendText(\n sender,\n `You're on the waitlist ✅\\n\\nThe moment a ${f.Pending_Category} expert is free, we'll reach out.`,\n );\n return;\n }\n if (action === \"cancel\") {\n await atUpdate(T_USERS, user.id, {\n Bot_State: \"AWAITING_QUERY\",\n Pending_Pro_ID: \"\",\n Pending_Pro_Phone: \"\",\n Pending_Category: \"\",\n });\n await sendText(\n sender,\n \"Okay, no problem. Let me know whenever you're ready 👋\",\n );\n return;\n }\n // Unrecognised input — re-show options\n await sendButtons(sender, \"Want to book this expert?\", [\n { id: \"confirm\", title: \"✅ Book this 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 atSearch(T_PROS, `{Pro Phone}=\"${proPhone}\"`);\n const proName = pro?.fields?.[\"Pro Name\"] || \"your expert\";\n const rateRaw = pro?.fields?.[\"Rate\"];\n const amountPaise = rateRaw\n ? Math.round(parseFloat(rateRaw) * 100)\n : SESSION_FEE_PAISE;\n const amountRs = amountPaise / 100;\n\n // If Razorpay is not configured, skip payment and go straight to session\n if (!RZP_KEY_ID) {\n console.log(\"No Razorpay keys — skipping payment gate\");\n await createSession(sender, user);\n return;\n }\n\n const link = await createPaymentLink(sender, category, proName, amountPaise);\n if (!link) {\n // Graceful fallback — skip payment gate\n console.log(\"Payment link creation failed — proceeding without payment\");\n await createSession(sender, user);\n return;\n }\n\n await atUpdate(T_USERS, user.id, {\n Bot_State: \"AWAITING_PAYMENT\",\n Pending_Pro_ID: f.Pending_Pro_ID,\n Pending_Pro_Phone: proPhone,\n Pending_Category: category,\n });\n\n await sendText(\n sender,\n `Almost there! To confirm your session with *${proName}*, please complete the ₹${amountRs} payment:\\n\\n` +\n `👉 ${link}\\n\\n` +\n `Once payment is confirmed, we'll connect you right away.\\n\\n` +\n `_Payment is secure via Razorpay. Reply CANCEL to abort._`,\n );\n}\n\n// ── Payment state handler (handles \"cancel\" or confirmation while waiting) ──\nasync function phaseAwaitingPayment(sender: string, user: any, msg: Msg) {\n const low = lc(msg.text);\n if (\n [\"cancel\", \"nahi\", \"no\", \"abort\"].includes(low) || msg.text === \"cancel\"\n ) {\n await atUpdate(T_USERS, user.id, {\n Bot_State: \"AWAITING_QUERY\",\n Pending_Pro_ID: \"\",\n Pending_Pro_Phone: \"\",\n Pending_Category: \"\",\n });\n await sendText(sender, \"Booking cancelled. Come back anytime 👋\");\n return;\n }\n // Payment confirmation comes via Razorpay callback, not via WhatsApp\n // But in case user messages us saying they paid, check and reassure\n await sendText(\n sender,\n \"⏳ We're waiting for payment confirmation. Once it goes through, you'll be connected automatically.\\n\\n\" +\n \"Tap the payment link again if needed, or reply *CANCEL* to abort.\",\n );\n}\n\n// ── Session creation (called after payment or directly if no payment gate) ──\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 pro = await atSearch(T_PROS, `{Pro Phone}=\"${proPhone}\"`);\n const proName = pro?.fields?.[\"Pro Name\"] || \"your expert\";\n\n // Create session as Paused until pro accepts\n const sessionRec = await atCreate(T_SESSIONS, {\n Users: [user.id],\n Professionals: [proId],\n Status: \"Paused\",\n \"Pro Phone\": proPhone,\n });\n await atUpdate(T_USERS, user.id, {\n \"Active Session?\": true,\n Bot_State: \"IN_SESSION\",\n Pending_Pro_ID: \"\",\n Pending_Pro_Phone: \"\",\n Pending_Category: \"\",\n });\n await sendText(\n sender,\n `⏳ *${proName}* has been notified. They'll confirm shortly — hang tight!`,\n );\n\n // Notify pro via template to open the 24h window\n const proWa = proPhone.replace(\"+\", \"\");\n const ok = await sendProTemplate(proWa, category);\n if (!ok) {\n await logError(\"notify_pro\", \"Template send to pro failed\", proWa, \"\");\n await sendText(\n ADMIN_PHONE,\n `⚠️ Failed to notify ${proName} (${proPhone}) for ${category} session. Buyer: +${sender}`,\n );\n await sendText(\n sender,\n \"We're having trouble reaching your expert. Our team has been alerted and will connect you manually — sorry for the inconvenience!\",\n );\n }\n}\n\n// ── IN_SESSION ───────────────────────────────────────────────────────────────\nasync function phaseInSession(sender: string, user: any, msg: Msg) {\n // Look up session by Users link (not the lookup field — that's unreliable)\n const session = await atSearch(\n T_SESSIONS,\n `AND(FIND(\"${user.id}\", ARRAYJOIN({Users})), {Status}=\"Active\")`,\n );\n const paused = await atSearch(\n T_SESSIONS,\n `AND(FIND(\"${user.id}\", ARRAYJOIN({Users})), {Status}=\"Paused\")`,\n );\n\n if (paused && !session) {\n await sendText(\n sender,\n \"⏸️ Your expert is getting things ready. Please hold on — they'll join shortly.\",\n );\n return;\n }\n if (!session) {\n await atUpdate(T_USERS, user.id, {\n Bot_State: \"POST_SESSION\",\n \"Active Session?\": false,\n });\n await sendText(sender, \"Your session has ended. I hope it was helpful!\");\n return;\n }\n\n const proPhone = session.fields[\"Pro Phone\"];\n const proWa = proPhone?.replace(\"+\", \"\");\n\n if (!msg.text && msg.type !== \"text\") {\n await sendText(\n sender,\n \"Only text can be relayed right now. Describe what you need in words — links are fine too.\",\n );\n return;\n }\n if (msg.isInteractive) {\n if (msg.text === \"end_yes\") {\n const proRec = await atSearch(T_PROS, `{Pro Phone}=\"${proPhone}\"`);\n const proName = proRec?.fields?.[\"Pro Name\"] || \"your expert\";\n await closeSession(session, proName, sender);\n return;\n }\n if (msg.text === \"end_no\") return;\n }\n if (!msg.text) return;\n\n if (\n [\"close\", \"end\", \"done\", \"finish\", \"stop\", \"band karo\"].includes(\n lc(msg.text),\n )\n ) {\n await sendButtons(sender, \"Are you sure you want to end this session?\", [\n { id: \"end_yes\", title: \"✅ Yes, end session\" },\n { id: \"end_no\", title: \"↩️ No, continue\" },\n ]);\n return;\n }\n\n if (!proWa) {\n await sendText(\n sender,\n \"⚠️ Could not reach your expert. Please contact support.\",\n );\n return;\n }\n await sendText(proWa, 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_\")) {\n 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: \"⭐ 1 — Poor\" },\n { id: \"rate_3\", title: \"⭐⭐⭐ 3 — Okay\" },\n { id: \"rate_5\", title: \"⭐⭐⭐⭐⭐ 5 — Great\" },\n ]);\n return;\n }\n\n const session = await atSearch(\n T_SESSIONS,\n `AND(FIND(\"${user.id}\", ARRAYJOIN({Users})), {Status}=\"Closed\")`,\n );\n if (session) {\n await atUpdate(T_SESSIONS, session.id, { Rating: rating });\n const pro = await atSearch(\n T_PROS,\n `{Pro Phone}=\"${session.fields[\"Pro Phone\"]}\"`,\n );\n if (pro) {\n const old = pro.fields[\"Rating\"] || rating;\n await atUpdate(T_PROS, pro.id, {\n Rating: Math.round(((old + rating) / 2) * 10) / 10,\n });\n }\n }\n\n if (rating >= 4) {\n await atUpdate(T_USERS, user.id, { Bot_State: \"POST_SESSION\" });\n await sendText(sender, \"🎉 Glad it helped! Thanks for the great rating.\");\n await phasePostSession(sender, user, msg, true);\n return;\n }\n if (rating === 3) {\n await atUpdate(T_USERS, user.id, { Bot_State: \"POST_SESSION\" });\n await sendText(sender, \"Thanks for the feedback 🙏\");\n await phasePostSession(sender, user, msg, true);\n return;\n }\n // Low rating\n await atUpdate(T_USERS, user.id, { Bot_State: \"GRIEVANCE\" });\n await sendText(\n sender,\n \"Really sorry about that 😔\\nWhat went wrong? We take this seriously and will look into it.\",\n );\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 atSearch(\n T_SESSIONS,\n `AND(FIND(\"${user.id}\", ARRAYJOIN({Users})), {Status}=\"Closed\")`,\n );\n let proName = \"an expert\";\n if (session) {\n const pro = await atSearch(\n T_PROS,\n `{Pro Phone}=\"${session.fields[\"Pro Phone\"]}\"`,\n );\n proName = pro?.fields?.[\"Pro Name\"] || proName;\n }\n await sendText(\n ADMIN_PHONE,\n `⚠️ Low rating complaint\\nBuyer: +${sender}\\nExpert: ${proName}\\n\\n\"${complaint}\"`,\n );\n await atUpdate(T_USERS, user.id, { Bot_State: \"POST_SESSION\" });\n await sendText(\n sender,\n \"Thank you — we've logged this and our team will follow up.\\n\\nWe take quality seriously and this will be reviewed.\",\n );\n await phasePostSession(sender, user, msg, true);\n}\n\n// ── POST_SESSION ──────────────────────────────────────────────────────────────\nasync function phasePostSession(\n sender: string,\n user: any,\n msg: Msg,\n justArrived = false,\n) {\n if (!justArrived && msg.isInteractive) {\n if (msg.text === \"new_consult\") {\n await atUpdate(T_USERS, user.id, {\n Bot_State: \"AWAITING_QUERY\",\n Pending_Pro_ID: \"\",\n Pending_Pro_Phone: \"\",\n 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(\n sender,\n \"❤️ Thanks! Share this link with friends and family:\\nhttps://wa.me/919354052769?text=Hi%20GoodBeetle\",\n );\n return;\n }\n }\n if (justArrived) {\n await sendButtons(sender, \"What would you like to do next?\", [\n { id: \"new_consult\", title: \"🔁 Book another 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) {\n if (!user) {\n await sendText(\n sender,\n `👋 Welcome to *GoodBeetle*!\\n\\nWe connect you with verified experts for quick consultations — right here on WhatsApp.\\n\\nWhat do you need help with today?`,\n );\n await showCategoryList(sender);\n return;\n }\n switch (state) {\n case \"IN_SESSION\": {\n const session = await atSearch(\n T_SESSIONS,\n `AND(FIND(\"${user.id}\", ARRAYJOIN({Users})), {Status}=\"Active\")`,\n );\n let proName = \"your expert\";\n if (session) {\n const pro = await atSearch(\n T_PROS,\n `{Pro Phone}=\"${session.fields[\"Pro Phone\"]}\"`,\n );\n proName = pro?.fields?.[\"Pro Name\"] || proName;\n }\n await sendText(\n sender,\n `You're in an active session with *${proName}*.\\n\\nSend your message or type *CLOSE* to end the session.`,\n );\n return;\n }\n case \"AWAITING_SELECTION\":\n await sendButtons(\n sender,\n \"You were booking an expert. Still interested?\",\n [\n { id: \"confirm\", title: \"✅ Book this expert\" },\n { id: \"change\", title: \"🔄 See another\" },\n { id: \"cancel\", title: \"✕ Cancel\" },\n ],\n );\n return;\n case \"AWAITING_PAYMENT\":\n await sendText(\n sender,\n \"⏳ You have a pending payment to complete your booking.\\n\\nCheck the payment link we sent, or reply *CANCEL* to abort.\",\n );\n return;\n case \"AWAITING_FEEDBACK\":\n await sendButtons(sender, \"How was your session?\", [\n { id: \"rate_1\", title: \"⭐ 1 — Poor\" },\n { id: \"rate_3\", title: \"⭐⭐⭐ 3 — Okay\" },\n { id: \"rate_5\", title: \"⭐⭐⭐⭐⭐ 5 — Great\" },\n ]);\n return;\n case \"POST_SESSION\":\n await sendButtons(sender, \"What would you like to do?\", [\n { id: \"new_consult\", title: \"🔁 Book another 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 \"\":\n \"Pick a category from the menu to find an expert, or describe what you need.\",\n AWAITING_QUERY:\n \"Pick a category from the menu, or type what you need and I'll find the right match.\",\n AWAITING_SELECTION:\n \"Tap *Book this expert* to confirm, *See another* to browse, or *Cancel* to start over.\",\n AWAITING_PAYMENT:\n \"Complete the payment to confirm your booking. Tap *CANCEL* to abort.\",\n IN_SESSION:\n \"Type your message to chat with your expert. Type *CLOSE* to end the session.\",\n AWAITING_FEEDBACK: \"Tap a star rating to rate your session (1–5).\",\n POST_SESSION: \"Tap *Book another session* to start a new consultation.\",\n };\n await sendText(sender, msgs[state] || msgs[\"\"]);\n}",[134],"pulls","branches","forks","envVars",{"_149":151,"_152":61},"connections",{"_149":61,"_150":61},"count","unfilledCount",10,"emptyCount",{"_44":133,"_33":134,"_31":135,"_127":-5,"_42":43,"_41":136,"_128":27,"_39":159,"_13":138,"_35":139,"_37":140,"_24":27,"_131":-5,"_156":160,"_28":161},{"_44":126,"_33":29,"_31":32,"_127":-5,"_42":43,"_41":14,"_128":27,"_39":155,"_13":130,"_35":36,"_37":38,"_24":27,"_131":-5,"_156":157,"_28":158},["D",1780675880339],"children",[],[29],["D",1780484153859],[],[134],["D",1780433758770],{"_95":94,"_102":38},{"_95":94,"_96":97,"_98":38,"_18":55,"_99":100,"_101":27},{"_13":84,"_33":85,"_44":43,"_86":45,"_87":-5,"_88":-5,"_89":-5,"_90":-5,"_91":-5,"_92":46,"_93":94},"ctx",{"_77":-5,"_121":199,"_200":201,"_202":203,"_204":27,"_205":27,"_206":27,"_207":25,"_208":-5,"_209":-7,"_210":-7,"_211":61,"_212":27,"_213":27,"_214":-5,"_215":27,"_216":27,"_217":27,"_218":-5},"ENV",{"_170":171,"_172":173,"_174":85,"_175":176,"_177":178,"_179":180,"_181":182,"_183":184,"_185":186,"_187":188,"_189":190,"_191":192,"_193":194,"_195":196,"_197":198},"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 · v19