[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_155":156,"_157":158},"routes/_app.x.$handle.$name",{"_95":94,"_32":45,"_104":85,"_27":37,"_13":14,"_105":-5,"_11":106,"_107":108,"_109":110,"_111":112,"_113":114,"_20":-5,"_115":-5,"_116":-5,"_117":25,"_118":119,"_120":121,"_122":-5,"_123":-5,"_124":125},"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",114,"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","askaoaoa_whatsapp.ts","latestPath","fileId","72f2fbbc-7c27-11f1-9141-1607ee4eb77e","name","fileType","http","content","// screenshots -> the resident just sends a photo in the chat.\n//\n// ENV VARS to set on this val:\n// ANTHROPIC_API_KEY - same key as the web val\n// SHEET_WEBHOOK_URL - same Apps Script webhook as the web val\n// GRAPH_VERSION - optional, defaults to v21.0\n\nimport { blob } from \"https://esm.town/v/std/blob\";\n\nconst TOKEN = Deno.env.get(\"WHATSAPP_TOKEN\") || \"\";\nconst PHONE_ID = Deno.env.get(\"WHATSAPP_PHONE_ID\") || \"\";\nconst VERIFY_TOKEN = Deno.env.get(\"VERIFY_TOKEN\") || \"\";\nconst GV = Deno.env.get(\"GRAPH_VERSION\") || \"v21.0\";\nconst BUILD = \"wa-2026-08-06-mccache-copilotfix\";\nconsole.log(\"WHATSAPP VAL BUILD: \" + BUILD);\n\n/* ---------- knowledge (imported from the data val, cached) ---------- */\nlet SYSTEM_CACHE = null;\nasync function getSystem() {\n if (SYSTEM_CACHE != null) return SYSTEM_CACHE;\n const u = Deno.env.get(\"DATA_URL\");\n if (!u) throw new Error(\"DATA_URL not set\");\n const mod = await import(u);\n SYSTEM_CACHE = mod.SYSTEM || \"\";\n return SYSTEM_CACHE;\n}\n\nconst CONFIG_URL = Deno.env.get(\"CONFIG_URL\");\nif (!CONFIG_URL) throw new Error(\"CONFIG_URL not set\");\nconst _cfg = await import(CONFIG_URL);\nconst CONFIG = _cfg.CONFIG;\nconst WA_PREFIX = \"aoaoa_\" + CONFIG.id + \"_wa_\"; // per-community blob namespace\nconst NAME = CONFIG.name;\nconst BLOCKS = (CONFIG.flats.blocks || []).map(function (b) {\n return b.toUpperCase();\n});\nconst BLOCKLIST = BLOCKS.length > 1\n ? BLOCKS.slice(0, -1).join(\", \") + \" or \" + BLOCKS.slice(-1)\n : (BLOCKS[0] || \"\");\nconst TOPICS = CONFIG.topics;\nconst DISCLAIMER = CONFIG.disclaimer;\nconst isValidFlat = (raw) => _cfg.isValidFlat(raw, CONFIG);\nconst normalizeFlat = (raw) => _cfg.normalizeFlat(raw, CONFIG);\n\nconst TOPIC_ROWS = [\n { id: \"Finance\", title: \"Finance\" },\n { id: \"Admin & Communication\", title: \"Admin & Comms\" },\n { id: \"Security/Parking\", title: \"Security / Parking\" },\n {\n id: \"MEP (Mechanical, Electrical, Plumbing)\",\n title: \"MEP\",\n description: \"Mechanical, Electrical, Plumbing\",\n },\n { id: \"Gardening\", title: \"Gardening\" },\n { id: \"Housekeeping\", title: \"Housekeeping\" },\n {\n id: \"Tech/IT (including MyGate)\",\n title: \"Tech / IT\",\n description: \"Including MyGate\",\n },\n { id: \"Water Management\", title: \"Water Management\" },\n { id: \"Clubhouse Management\", title: \"Clubhouse Mgmt\" },\n { id: \"Others\", title: \"Others\" },\n];\n\nlet MANIFEST_CACHE = {}, MANIFEST_TS = {};\nfunction manifestIfWarm(mc) {\n const key = mc ? \"mc\" : \"all\";\n if (MANIFEST_CACHE[key] != null) return MANIFEST_CACHE[key];\n return \"\";\n}\nasync function getManifest(mc) {\n const key = mc ? \"mc\" : \"all\";\n const now = Date.now();\n // one timing out and leaving the model with an empty library.\n if (\n MANIFEST_CACHE[key] != null && (now - (MANIFEST_TS[key] || 0)) < 1800000\n ) return MANIFEST_CACHE[key];\n let txt = null;\n try {\n const r = await sheetGet(\"q=docs\" + (mc ? \"&scope=mc\" : \"\"), 12000);\n if (r && r.ok && Array.isArray(r.docs)) {\n txt = r.docs.length\n ? (\"DOCUMENT LIBRARY (open the relevant one with get_document before answering):\\n\" +\n r.docs.map(function (x) {\n return \"- \" + x.title +\n (x.description ? \": \" + x.description : \"\") +\n (x.audience === \"mc\" ? \" [committee-only]\" : \"\");\n }).join(\"\\n\"))\n : \"\";\n }\n } catch (e) {}\n // load the list.\n if (txt === null) return \"DOCUMENT_LIBRARY_UNAVAILABLE\";\n MANIFEST_CACHE[key] = txt;\n MANIFEST_TS[key] = now;\n return txt;\n}\n\nlet TOPICS_CACHE = null, TOPICS_TS = 0;\nasync function getTopics() {\n const now = Date.now();\n if (TOPICS_CACHE !== null && (now - TOPICS_TS) < 300000) return TOPICS_CACHE;\n let list = null;\n try {\n const r = await sheetGet(\"q=topics\", 12000);\n if (r && r.ok && Array.isArray(r.topics) && r.topics.length) {\n list = r.topics;\n }\n } catch (e) {}\n TOPICS_CACHE = (list && list.length) ? list : CONFIG.topics; // fallback to config if the sheet has none\n TOPICS_TS = now;\n return TOPICS_CACHE;\n}\n\nlet TOOLS_CACHE = null;\nasync function getTools(TOPICS) {\n if (TOOLS_CACHE) return TOOLS_CACHE;\n const u = Deno.env.get(\"DATA_URL\");\n if (!u) throw new Error(\"DATA_URL not set\");\n const mod = await import(u);\n if (typeof mod.buildTools !== \"function\") {\n console.log(\n \"FATAL: data val at DATA_URL has no buildTools export - update DATA_URL to the latest data val module URL.\",\n );\n throw new Error(\n \"Data val is out of date: no buildTools export. Update DATA_URL.\",\n );\n }\n TOOLS_CACHE = mod.buildTools(TOPICS);\n return TOOLS_CACHE;\n}\n\nconst RELEASES_TEXT = \"*What's new in \" + NAME +\n \" \\u2014 v4.1*\\n\\n\\u2022 Ask who holds each committee post \\u2014 President, Secretary, Treasurer and more \\u2014 with their name and number.\\n\\u2022 Ask who handles a particular area (water, security, housekeeping\\u2026) and reach the right point of contact.\\n\\u2022 Get the committee's official email to write in directly.\\n\\u2022 Answers stay in clear, everyday language \\u2014 no clause numbers.\";\n\nlet ACTIONS_CACHE = null;\nasync function getActions() {\n if (ACTIONS_CACHE != null) return ACTIONS_CACHE;\n const u = Deno.env.get(\"DATA_URL\");\n if (!u) throw new Error(\"DATA_URL not set\");\n const mod = await import(u);\n if (typeof mod.buildActions !== \"function\") {\n console.log(\n \"FATAL: data val at DATA_URL has no buildActions export - update DATA_URL to the latest data val module URL.\",\n );\n throw new Error(\n \"Data val is out of date: no buildActions export. Update DATA_URL.\",\n );\n }\n ACTIONS_CACHE = mod.buildActions(\"whatsapp\");\n const _sys = String(mod.SYSTEM || \"\");\n console.log(\n \"prompt loaded: actions=\" + ACTIONS_CACHE.length + \" chars, system=\" +\n _sys.length +\n \", grounding_rule=\" + (_sys.indexOf(\"NEVER STATE A PERSON\") >= 0\n ? \"yes\"\n : \"NO - DATA VAL IS STALE\"),\n );\n return ACTIONS_CACHE;\n}\n\nconst WEBHOOK = Deno.env.get(\"SHEET_WEBHOOK_URL\") || \"\";\nconst SHEET_SECRET = Deno.env.get(\"SHEET_SECRET\") || \"\";\n\n/* ---------- flat validation (same rules as the web app) ---------- */\n\n/* ---------- IST date helpers (same as the web app) ---------- */\nfunction istNow() {\n return new Date(Date.now() + 5.5 * 3600 * 1000);\n}\nfunction istTodayISO() {\n const d = istNow();\n return d.getUTCFullYear() + \"-\" +\n String(d.getUTCMonth() + 1).padStart(2, \"0\") + \"-\" +\n String(d.getUTCDate()).padStart(2, \"0\");\n}\nfunction daysSince(dateStr) {\n const m = String(dateStr || \"\").match(/^(\\d{4})-(\\d{2})-(\\d{2})$/);\n if (!m) return null;\n const created = Date.UTC(+m[1], +m[2] - 1, +m[3]);\n if (isNaN(created)) return null;\n const d = istNow();\n const today = Date.UTC(d.getUTCFullYear(), d.getUTCMonth(), d.getUTCDate());\n return Math.floor((today - created) / 86400000);\n}\n\n/* ---------- Google-Sheet logging (same webhook as the web app) ---------- */\nasync function postSheet(payload) {\n if (!WEBHOOK) {\n return {\n ok: false,\n note: \"Logging is not set up yet (no SHEET_WEBHOOK_URL).\",\n };\n }\n const ctl = new AbortController();\n const timer = setTimeout(() => ctl.abort(), 15000); // writes get longer than reads, but not forever\n try {\n if (SHEET_SECRET) payload.secret = SHEET_SECRET;\n const body = JSON.stringify(payload);\n let r = await fetch(WEBHOOK, {\n method: \"POST\",\n headers: { \"content-type\": \"application/json\" },\n body: body,\n redirect: \"manual\",\n signal: ctl.signal,\n });\n let hops = 0;\n while (r.status >= 300 && r.status < 400 && hops < 5) {\n const loc = r.headers.get(\"location\");\n if (!loc) break;\n hops++;\n r = await fetch(loc, { redirect: \"manual\", signal: ctl.signal });\n }\n const d = await r.json();\n return (d && d.ok)\n ? { ok: true, reference: d.reference, url: d.url }\n : { ok: false, note: \"The logging service reported an error.\" };\n } catch (e) {\n if (e && e.name === \"AbortError\") {\n console.log(\"postSheet timed out: \" + (payload && payload.type));\n }\n return { ok: false, note: \"Could not reach the logging service.\" };\n } finally {\n clearTimeout(timer);\n }\n}\n\nlet STATUS_CACHE = { t: 0, v: \"\" };\n/* Generous timeout, purely as a backstop. Apps Script is normally fast; this exists only so that a\n genuine hang can never run past the platform request limit and leave the resident with silence.\n Do NOT tighten these or make these calls concurrent - Apps Script serialises executions of the same\n script, so parallel calls queue behind each other and time out even when the script is healthy. */\nasync function sheetGet(query, timeoutMs, critical) {\n if (!WEBHOOK) {\n return {\n ok: false,\n note: \"Lookups are not set up yet (no SHEET_WEBHOOK_URL).\",\n };\n }\n const ctl = new AbortController();\n const timer = setTimeout(() => ctl.abort(), timeoutMs || 30000);\n try {\n const url = WEBHOOK + \"?\" + query +\n (SHEET_SECRET ? \"&secret=\" + encodeURIComponent(SHEET_SECRET) : \"\");\n let r = await fetch(url, { redirect: \"manual\", signal: ctl.signal });\n let hops = 0;\n while (r.status >= 300 && r.status < 400 && hops < 5) {\n const loc = r.headers.get(\"location\");\n if (!loc) break;\n hops++;\n r = await fetch(loc, { redirect: \"manual\", signal: ctl.signal });\n }\n return await r.json();\n } catch (e) {\n if (e && e.name === \"AbortError\") {\n console.log(\"sheetGet timed out: \" + String(query).slice(0, 60));\n }\n return { ok: false, note: \"Could not reach the lookup service.\" };\n } finally {\n clearTimeout(timer);\n }\n}\n/* ---------- context cache ----------\n Site status, the document list and the topic list are three separate Apps Script round trips, and\n Val Town hands us a COLD isolate on essentially every message - so every resident question paid\n three cold Apps Script executions (~5s each, which is the 15-31s \"preflight\" seen in production).\n These three change rarely, so they are cached together in Val Town's own blob store.\n IMPORTANT: the calls below are still SEQUENTIAL. Apps Script serialises concurrent executions of\n the same script, so parallelising them makes each queue behind the others and time out. The cache\n is what makes this fast; parallelism made it worse. Do not \"optimise\" it back into a Promise.all.\n If Apps Script is unreachable we keep serving the last known copy - a slightly stale status banner\n beats a failed answer. */\nconst CTX_TTL_MS = 1800000; // 30 minutes. Sporadic resident traffic means a short TTL keeps\nasync function invalidateContext() {\n for (const k of [\"ctx_cache_all\", \"ctx_cache_mc\"]) {\n try {\n await blob.delete(k);\n } catch (e) {}\n }\n}\nasync function getMcContacts() {\n const bkey = \"mc_cache\";\n let cached = null;\n try {\n cached = await blob.getJSON(bkey);\n } catch (e) {}\n if (cached && cached.d && (Date.now() - (cached.t || 0)) < 1800000) {\n return cached.d; // 30 min\n }\n const d = await sheetGet(\"q=mc\", 12000);\n if (d && d.ok) {\n try {\n await blob.setJSON(bkey, { t: Date.now(), d: d });\n } catch (e) {}\n return d;\n }\n if (cached && cached.d) {\n console.log(\"q=mc unreachable - serving last known committee directory\");\n return cached.d;\n }\n return d;\n}\nasync function invalidateMc() {\n try {\n await blob.delete(\"mc_cache\");\n } catch (e) {}\n}\nasync function loadContext(mc) {\n const bkey = \"ctx_cache_\" + (mc ? \"mc\" : \"all\");\n let cached = null;\n try {\n cached = await blob.getJSON(bkey);\n } catch (e) {}\n if (cached && cached.d && (Date.now() - (cached.t || 0)) < CTX_TTL_MS) {\n return cached.d;\n }\n\n const d = {};\n const s1 = Date.now();\n d.status = await sheetGet(\"q=status\", 12000);\n console.log(\" q=status \" + (Date.now() - s1) + \"ms\");\n const s2 = Date.now();\n d.docs = await sheetGet(\"q=docs\" + (mc ? \"&scope=mc\" : \"\"), 12000);\n console.log(\" q=docs \" + (Date.now() - s2) + \"ms\");\n const s3 = Date.now();\n d.topics = await sheetGet(\"q=topics\", 12000);\n console.log(\" q=topics \" + (Date.now() - s3) + \"ms\");\n\n const prev = (cached && cached.d) ? cached.d : {};\n if (!(d.status && d.status.ok)) d.status = prev.status || d.status;\n if (!(d.docs && d.docs.ok)) d.docs = prev.docs || d.docs;\n if (!(d.topics && d.topics.ok)) d.topics = prev.topics || d.topics;\n\n const good = (d.status && d.status.ok) || (d.docs && d.docs.ok) ||\n (d.topics && d.topics.ok);\n if (!good) {\n if (prev && (prev.status || prev.docs || prev.topics)) {\n console.log(\"context lookups failed - serving the last known copy\");\n return prev;\n }\n return d;\n }\n const full = (d.status && d.status.ok) && (d.docs && d.docs.ok) &&\n (d.topics && d.topics.ok);\n try {\n await blob.setJSON(bkey, {\n t: full ? Date.now() : ((cached && cached.t) || 0),\n d: d,\n });\n } catch (e) {}\n return d;\n}\nfunction applyContext(d, mc) {\n const now = Date.now();\n let v = \"\";\n if (\n d.status && d.status.ok && Array.isArray(d.status.active) &&\n d.status.active.length\n ) {\n v = d.status.active.map((a) => (a && a.message != null) ? a.message : a)\n .filter(Boolean).join(\" | \");\n }\n if (d.status && d.status.ok) STATUS_CACHE = { t: now, v: v };\n if (\n d.topics && d.topics.ok && Array.isArray(d.topics.topics) &&\n d.topics.topics.length\n ) {\n TOPICS_CACHE = d.topics.topics;\n TOPICS_TS = now;\n }\n if (d.docs && d.docs.ok && Array.isArray(d.docs.docs)) {\n const key = mc ? \"mc\" : \"all\";\n let txt = \"\";\n if (d.docs.docs.length) {\n txt =\n \"DOCUMENT LIBRARY (open the relevant one with get_document before answering):\\n\" +\n d.docs.docs.map(function (x) {\n return \"- \" + x.title + (x.description ? \": \" + x.description : \"\") +\n (x.audience === \"mc\" ? \" [committee-only]\" : \"\");\n }).join(\"\\n\");\n }\n MANIFEST_CACHE[key] = txt;\n MANIFEST_TS[key] = now;\n }\n}\nasync function getStatus() {\n const now = Date.now();\n if (now - STATUS_CACHE.t < 60000) return STATUS_CACHE.v;\n let v = \"\";\n try {\n const d = await sheetGet(\"q=status\", 10000);\n if (d && d.ok && Array.isArray(d.active) && d.active.length) {\n v = d.active.map((a) => (a && a.message != null) ? a.message : a).filter(\n Boolean,\n ).join(\" | \");\n }\n } catch (e) {}\n STATUS_CACHE = { t: now, v: v };\n return v;\n}\n\nlet SYSTEM_COPILOT_CACHE = null;\nasync function getCopilotSystem() {\n if (SYSTEM_COPILOT_CACHE) return SYSTEM_COPILOT_CACHE;\n try {\n const mod = await import(Deno.env.get(\"DATA_URL\"));\n SYSTEM_COPILOT_CACHE = mod.SYSTEM_COPILOT || \"\";\n } catch (e) {\n SYSTEM_COPILOT_CACHE = \"\";\n }\n return SYSTEM_COPILOT_CACHE;\n}\n\nasync function copilotAnswer(KEY, history, sys) {\n const dd = await sheetGet(\"q=export\", 20000);\n const dataStr = (dd && dd.ok && dd.data)\n ? JSON.stringify(dd.data)\n : \"(community data could not be loaded right now - tell the committee member you couldn't reach it and to try again in a moment)\";\n // do NOT block the whole answer on a slow q=docs - the copilot's core job (summaries, counts,\n // offered until the cache warms, which is a fine degradation.\n const manifest = manifestIfWarm(true);\n const system = [\n {\n type: \"text\",\n text: await getCopilotSystem(),\n cache_control: { type: \"ephemeral\" },\n },\n ];\n if (sys) {\n system.push({\n type: \"text\",\n text: \"REFERENCE \\u2014 the association's rules/instructions:\\n\\n\" + sys,\n });\n }\n if (manifest) system.push({ type: \"text\", text: manifest });\n system.push({\n type: \"text\",\n text: \"Today's date: \" + istTodayISO() +\n \" (IST).\\n\\nCOMMUNITY DATA (JSON, newest first):\\n\" + dataStr,\n });\n const tools = [{\n name: \"get_document\",\n description:\n \"Open any association document from the DOCUMENT LIBRARY \\u2014 including committee-only ones (e.g. boom-barrier/vehicle logs, security attendance) \\u2014 and get its full text or data to analyze. Pass the exact Title from the library.\",\n input_schema: {\n type: \"object\",\n properties: {\n title: {\n type: \"string\",\n description: \"The exact Title from the DOCUMENT LIBRARY.\",\n },\n },\n required: [\"title\"],\n },\n }];\n let msgs = history.slice(-12).map((m) => ({\n role: m && m.role === \"assistant\" ? \"assistant\" : \"user\",\n content: String((m && m.content) || \"\").slice(0, 6000),\n }));\n try {\n for (let step = 0; step < 6; step++) {\n const r = await fetch(\"https://api.anthropic.com/v1/messages\", {\n method: \"POST\",\n headers: {\n \"content-type\": \"application/json\",\n \"x-api-key\": KEY,\n \"anthropic-version\": \"2023-06-01\",\n },\n body: JSON.stringify({\n model: CONFIG.models.copilot,\n max_tokens: 2000,\n temperature: 0,\n system: system,\n tools: tools,\n messages: msgs,\n }),\n });\n const cd = await r.json();\n if (r.status !== 200) {\n return \"The copilot is having trouble right now. Please try again.\";\n }\n if (cd.stop_reason === \"tool_use\") {\n const results = [];\n for (const b of (cd.content || [])) {\n if (b.type === \"tool_use\" && b.name === \"get_document\") {\n const res = await sheetGet(\n \"q=doc&scope=mc&title=\" +\n encodeURIComponent((b.input && b.input.title) || \"\"),\n 45000,\n true,\n );\n results.push({\n type: \"tool_result\",\n tool_use_id: b.id,\n content: JSON.stringify(res).slice(0, 120000),\n });\n } else if (b.type === \"tool_use\") {\n results.push({\n type: \"tool_result\",\n tool_use_id: b.id,\n content: \"(unavailable)\",\n });\n }\n }\n msgs.push({ role: \"assistant\", content: cd.content });\n msgs.push({ role: \"user\", content: results });\n continue;\n }\n return (cd.content || []).map((c) => c.type === \"text\" ? c.text : \"\")\n .filter(Boolean).join(\"\\n\").trim() ||\n \"I couldn't produce an answer for that.\";\n }\n return \"That needed too many steps \\u2014 please narrow the question.\";\n } catch (e) {\n return \"The copilot couldn't reach the service just now.\";\n }\n}\n\nfunction complaintRef(t) {\n const m = String(t || \"\").match(/AO-C-\\d{6}-\\d{4}/i);\n return m ? m[0].toUpperCase() : \"\";\n}\nfunction isComplaintStatus(t) {\n const s = String(t || \"\").trim().toLowerCase().replace(/[?.!]+$/, \"\");\n if (complaintRef(s)) return true;\n return [\n \"my complaints\",\n \"my complaint\",\n \"complaint status\",\n \"complaints status\",\n \"check my complaints\",\n \"check my complaint\",\n \"check complaint status\",\n \"status of my complaint\",\n \"status of my complaints\",\n \"track my complaint\",\n \"track my complaints\",\n \"complaint update\",\n \"complaint updates\",\n ].includes(s);\n}\nfunction formatComplaintsWA(d, ref) {\n if (!d || !d.ok) {\n return \"I couldn't check the complaint status just now. Please try again in a moment.\";\n }\n const list = d.complaints || [];\n if (!list.length) {\n return ref\n ? \"I couldn't find a complaint with that reference for your flat. Please double-check it (it looks like AO-C-...), or describe the issue and I'll log a new complaint.\"\n : \"You don't have any complaints logged yet. If something needs fixing, just describe it and I'll raise a complaint for you.\";\n }\n const lines = list.map(function (c) {\n const st = c.status || \"Open\";\n const emoji = /resolv|closed|done/i.test(st)\n ? \"\\u2705\"\n : /progress|working|assign/i.test(st)\n ? \"\\uD83D\\uDD27\"\n : \"\\uD83D\\uDD5B\";\n return emoji + \" *\" + (c.reference || \"\") + \"* \\u2014 \" +\n (c.category || \"\") + \"\\n_\" + (c.issue || \"\") + \"_\\nStatus: *\" + st + \"*\";\n });\n return \"Here's the latest on your complaint\" + (list.length > 1 ? \"s\" : \"\") +\n \":\\n\\n\" + lines.join(\"\\n\\n\");\n}\n\nfunction stripCites(t) {\n if (!t) return t;\n let s = String(t);\n s = s.replace(\n /\\*?\\s*\$(?:[^()]*?)(?:clause|section|article|rule|bye-?law|point|item|para(?:graph)?)\\s*\\d+[a-z]?(?:\\.\\d+)*(?:[^()]*?)\$\\s*\\*?/gi,\n \"\",\n );\n // inline references, e.g. \"Clause 43.9\", \"Section 14\", \"Bye-Law 11.3\"\n s = s.replace(\n /\\b(?:bye-?laws?[,\\s]*)?(?:clause|section|article|bye-?law)s?\\s*\\d+[a-z]?(?:\\.\\d+)*(?:\\s*(?:,|and|&)\\s*\\d+[a-z]?(?:\\.\\d+)*)*/gi,\n \"the association's rules\",\n );\n // tidy residue\n s = s.replace(/\$\\s*\$/g, \"\");\n s = s.replace(/[ \\t]{2,}/g, \" \");\n s = s.replace(/\\s+([.,;:])/g, \"$1\");\n s = s.replace(\n /the association's rules(?:\\s*(?:,|and|&)\\s*the association's rules)+/gi,\n \"the association's rules\",\n );\n return s.trim();\n}\n\nasync function runTool(name, input, flat) {\n input = input || {};\n if (name === \"log_suggestion\") {\n return await postSheet({\n type: \"suggestion\",\n topic: input.topic || \"\",\n suggestion: input.suggestion || \"\",\n flat: flat || \"\",\n });\n }\n if (name === \"update_suggestion\") {\n const payload = {\n type: \"suggestion_update\",\n reference: input.reference || \"\",\n };\n if (typeof input.willing_to_join_subcommittee === \"boolean\") {\n payload.joinSubcommittee = input.willing_to_join_subcommittee;\n }\n if (input.name) payload.name = input.name;\n if (input.email) payload.email = input.email;\n return await postSheet(payload);\n }\n if (name === \"log_escalation\") {\n const days = daysSince(input.ticket_created_date);\n if (days === null) {\n return {\n ok: false,\n note:\n \"The ticket date was not understood. Ask the resident to type it clearly (e.g. 3 July 2025).\",\n };\n }\n if (days < 0) {\n return {\n ok: false,\n note:\n \"That ticket date is in the future. Ask the resident to re-check and give the correct date.\",\n };\n }\n if (days < 1) {\n return {\n ok: false,\n note:\n \"The MyGate ticket was created today, less than a day ago. Do NOT escalate yet. Kindly ask the resident to wait a little longer so the facility team (FMS) can act, and to escalate once it is more than a day old. If they'd like to nudge it sooner, they can call the FMS manager, \" +\n CONFIG.fmsContact + \".\",\n };\n }\n return await postSheet({\n type: \"escalation\",\n name: input.name || \"\",\n flat: flat || \"\",\n category: input.category || \"\",\n issue: input.issue || \"\",\n ticketNo: input.ticket_id || \"\",\n ticketDate: input.ticket_created_date || \"\",\n daysOpen: days,\n email: input.email || \"\",\n });\n }\n if (name === \"log_question\") {\n if (!input.email) {\n return {\n ok: false,\n note:\n \"An email is required so the committee can reply. Please ask the resident for an email before logging the question.\",\n };\n }\n return await postSheet({\n type: \"question\",\n topic: input.topic || \"\",\n question: input.question || \"\",\n email: input.email || \"\",\n name: input.name || \"\",\n flat: flat || \"\",\n });\n }\n if (name === \"log_complaint\") {\n if (!input.email) {\n return {\n ok: false,\n note:\n \"An email is required so the committee can follow up and copy the resident in. Please ask the resident for an email before logging the complaint.\",\n };\n }\n return await postSheet({\n type: \"complaint\",\n category: input.category || \"\",\n issue: input.issue || \"\",\n name: input.name || \"\",\n email: input.email || \"\",\n flat: flat || \"\",\n });\n }\n if (name === \"update_complaint\") {\n return await postSheet({\n type: \"complaint_update\",\n reference: input.reference || \"\",\n name: input.name || \"\",\n email: input.email || \"\",\n });\n }\n if (name === \"check_complaint_status\") {\n let query = \"q=complaint&flat=\" + encodeURIComponent(flat || \"\");\n if (input.reference) {\n query += \"&ref=\" + encodeURIComponent(String(input.reference).trim());\n }\n return await sheetGet(query);\n }\n if (name === \"get_resident_info\") {\n if (!flat) {\n return {\n ok: false,\n note: \"The resident's flat isn't known yet; ask for their flat first.\",\n };\n }\n return await sheetGet(\"q=resident&flat=\" + encodeURIComponent(flat), 15000);\n }\n if (name === \"log_recommendation\") {\n return await postSheet({\n type: \"recommendation\",\n category: input.category || \"\",\n provider: input.provider || \"\",\n contact: input.contact || \"\",\n area: input.area || \"\",\n note: input.note || \"\",\n credit: !!input.credit,\n flat: flat || \"\",\n });\n }\n if (name === \"get_recommendations\") {\n return await sheetGet(\n \"q=recommend&query=\" + encodeURIComponent(input.query || \"\"),\n 15000,\n );\n }\n if (name === \"log_agent_feedback\") {\n return await postSheet({\n type: \"agent_feedback\",\n kind: input.kind || \"\",\n stars: (input.stars >= 1 && input.stars <= 5) ? input.stars : \"\",\n rating: input.rating || \"\",\n comment: input.comment || \"\",\n flat: input.anonymous ? \"\" : (flat || \"\"),\n channel: \"WhatsApp\",\n });\n }\n if (name === \"get_mc_contacts\") {\n return await getMcContacts();\n }\n if (name === \"get_document\") {\n return await sheetGet(\n \"q=doc&title=\" + encodeURIComponent(input.title || \"\"),\n 45000,\n true,\n );\n }\n return { ok: false, note: \"Unknown action.\" };\n}\n\n/* ---------- Claude (same model + tool loop as the web app) ---------- */\nasync function callClaude(KEY, systemBlocks, messages, tools) {\n const r = await fetch(\"https://api.anthropic.com/v1/messages\", {\n method: \"POST\",\n headers: {\n \"content-type\": \"application/json\",\n \"x-api-key\": KEY,\n \"anthropic-version\": \"2023-06-01\",\n },\n body: JSON.stringify({\n model: CONFIG.models.resident,\n max_tokens: 1000,\n temperature: 0,\n system: systemBlocks,\n tools: tools || (await getTools(await getTopics())),\n messages,\n }),\n });\n return { status: r.status, data: await r.json() };\n}\n\nasync function answer(KEY, SYSTEM, history, flat, lang) {\n const messages = history.slice(-14).map((m) => ({\n role: m && m.role === \"assistant\" ? \"assistant\" : \"user\",\n content: String((m && m.content) || \"\").slice(0, 4000),\n }));\n\n const priorRefs = [];\n for (const m of messages) {\n if (m.role !== \"assistant\") continue;\n const found = m.content.match(/AO-(?:C-)?\\d{6}-\\d{4}/g);\n if (found) {\n for (const r of found) if (!priorRefs.includes(r)) priorRefs.push(r);\n }\n }\n const refLine = priorRefs.length\n ? \" NOTE: This conversation has already saved record(s) with reference \" +\n priorRefs.join(\", \") +\n \". These are already logged. Do NOT call any log_ tool again for an item that already has a reference \\u2014 that creates a duplicate. To add a name, email, or other detail, use the matching UPDATE tool: update_suggestion for a suggestion reference, or update_complaint for an AO-C-... complaint reference. Only log a brand-new, clearly different item the resident raises now.\"\n : \"\";\n\n let langLine;\n if (lang === \"hi\") {\n langLine =\n \" Reply to the resident in Hindi (Devanagari script). Keep any line that starts with 'VERDICT:' and its label in English exactly, and keep any [[...]] tokens exactly as written.\";\n } else if (lang === \"kn\") {\n langLine =\n \" Reply to the resident in Kannada. Keep any line that starts with 'VERDICT:' and its label in English exactly, and keep any [[...]] tokens exactly as written.\";\n } else if (lang === \"en\") {\n langLine =\n \" Reply to the resident in English. Keep any [[...]] tokens exactly as written.\";\n } else {langLine =\n \" The resident may write in English, Hindi, or Kannada. Reply in the same language they used. Keep any line that starts with 'VERDICT:' and its label in English exactly, and keep any [[...]] tokens exactly as written.\";}\n\n const _t0 = Date.now();\n // time is how this worked originally, and it is faster in practice.\n const _ta = Date.now();\n const actionsText = await getActions();\n console.log(\"actions \" + (Date.now() - _ta) + \"ms\");\n const _tc = Date.now();\n applyContext(await loadContext(false), false);\n console.log(\"context \" + (Date.now() - _tc) + \"ms\");\n const siteStatus = await getStatus();\n const manifest = await getManifest();\n console.log(\"preflight \" + (Date.now() - _t0) + \"ms\");\n const statusLine = siteStatus\n ? \" CURRENT SITE STATUS (live alerts posted by the committee/security): \" +\n siteStatus +\n \". If the resident asks about power, water, lifts, or what's happening on site, tell them this.\"\n : \" CURRENT SITE STATUS: No site alerts are posted right now. If a resident reports a problem, do not claim everything is working \\u2014 suggest they contact security/FMS or log a complaint.\";\n const systemBlocks = [\n {\n type: \"text\",\n text: SYSTEM + actionsText +\n (manifest === \"DOCUMENT_LIBRARY_UNAVAILABLE\"\n ? \"\\n\\nNOTE: your DOCUMENT LIBRARY could not be loaded right now due to a temporary service issue. You do NOT currently know which documents exist. For any question that depends on the association's rules or documents, DO NOT say the information is missing or that no such document exists - instead tell the resident you are having trouble reaching the documents this moment and ask them to try again shortly, or offer to pass the question to the committee. Non-document questions can be answered normally.\"\n : (manifest ? \"\\n\\n\" + manifest : \"\")),\n cache_control: { type: \"ephemeral\" },\n },\n {\n type: \"text\",\n text: \"Today's date is \" + istTodayISO() +\n \" (YYYY-MM-DD), India Standard Time. \" +\n (flat\n ? \"The resident's flat is \" + flat + \".\"\n : \"You do not yet know the resident's flat.\") +\n langLine + refLine + statusLine,\n },\n ];\n\n let msgs = messages;\n const _tools = await getTools(await getTopics());\n for (let step = 0; step < 6; step++) {\n const _ts = Date.now();\n const { status, data } = await callClaude(KEY, systemBlocks, msgs, _tools);\n console.log(\n \"model turn \" + (step + 1) + \": \" + (Date.now() - _ts) + \"ms status \" +\n status,\n );\n if (status !== 200) {\n console.log(\n \"anthropic error\",\n status,\n JSON.stringify(data && data.error ? data.error : data).slice(0, 400),\n );\n return \"I'm having trouble reaching the assistant right now. Please try again in a moment.\";\n }\n if (data.stop_reason === \"tool_use\") {\n msgs = msgs.concat([{ role: \"assistant\", content: data.content }]);\n const results = [];\n for (const block of data.content) {\n if (block.type === \"tool_use\") {\n const _tt = Date.now();\n const result = await runTool(block.name, block.input, flat);\n console.log(\"tool \" + block.name + \": \" + (Date.now() - _tt) + \"ms\");\n results.push({\n type: \"tool_result\",\n tool_use_id: block.id,\n content: JSON.stringify(result),\n });\n }\n }\n msgs = msgs.concat([{ role: \"user\", content: results }]);\n continue;\n }\n return stripCites(\n (data.content || []).map((c) => c.type === \"text\" ? c.text : \"\").filter(\n Boolean,\n ).join(\"\\n\").trim(),\n ) ||\n \"I couldn't find an answer to that. Could you rephrase?\";\n }\n return \"That took a few too many steps \\u2014 could you try asking again?\";\n}\n\n/* ---------- format Claude's reply for WhatsApp ---------- */\n/* ---------- committee-conduct detector ----------\n The verification note is a safety feature, so it must not depend on the model remembering to emit\n [[VERIFY]]. This is the deterministic backstop: if the RESIDENT's question is about what the\n committee or an office-bearer may, must, or cannot do, the note is attached regardless of what\n came back from the model. Over-attaching costs one quiet italic line; under-attaching sends an\n unqualified ruling about named people out into a WhatsApp group. */\nconst COMMITTEE_RX =\n /\\b(committee|managing committee|\\bmc\\b|office[- ]?bearer|president|secretary|treasurer|association)\\b/i;\nconst CONDUCT_RX =\n /\\b(can|cannot|can't|could|allowed|permitted|entitled|empower\\w*|authoris\\w*|authoriz\\w*|legal|illegal|valid|right|rights|power|powers|must|should|supposed to|oblig\\w*|breach\\w*|violat\\w*|wrong\\w*|unfair\\w*|arbitrar\\w*|overcharg\\w*|misus\\w*|answerable|accountab\\w*|unilateral\\w*|whim|sudden\\w*)\\b/i;\nfunction isCommitteeConductQuestion(t) {\n const s = String(t || \"\");\n if (!s.trim()) return false;\n return COMMITTEE_RX.test(s) && CONDUCT_RX.test(s);\n}\n\nfunction formatForWhatsApp(raw, askedText) {\n let s = String(raw || \"\");\n const wantsTopic = /\\[\\[PICK_TOPIC\\]\\]/.test(s);\n const wantsYesNo = /\\[\\[PICK_YESNO\\]\\]/.test(s);\n const attachM = s.match(/\\[\\[ATTACH:([^\\]]*)\\]\\]/);\n const attachRef = attachM ? attachM[1].trim() : null;\n s = s.replace(/\\[\\[PICK_(DATE|TOPIC|YESNO)\\]\\]/g, \"\").replace(\n /\\[\\[ATTACH:[^\\]]*\\]\\]/g,\n \"\",\n ).trim();\n // travel without the \"this is not a ruling\" note.\n let wantsVerify = false;\n if (/\\[\\[VERIFY\\]\\]/i.test(s)) {\n wantsVerify = true;\n s = s.replace(/\\[\\[VERIFY\\]\\]/gi, \"\");\n }\n\n // verdict line -> emoji + bold\n let hadVerdict = false;\n s = s.replace(/^\\s*VERDICT:\\s*(.+?)\\s*$/im, (m, label) => {\n hadVerdict = true;\n const v = label.toLowerCase();\n let e = \"\\u2139\\uFE0F\";\n if (v.startsWith(\"not permitted\") || v.startsWith(\"not allowed\")) {\n e = \"\\u26D4\";\n } else if (v.startsWith(\"conditional\")) e = \"\\u26A0\\uFE0F\";\n else if (v.startsWith(\"not covered\")) e = \"\\u2139\\uFE0F\";\n else if (\n v.includes(\"within\") || v.includes(\"permitted\") || v.includes(\"allowed\")\n ) e = \"\\u2705\";\n return e + \" *\" + label.trim() + \"*\";\n });\n s = s.replace(/\\*\\*(.+?)\\*\\*/g, \"*$1*\"); // markdown bold -> WhatsApp bold\n if (\n (hadVerdict || wantsVerify || isCommitteeConductQuestion(askedText)) &&\n CONFIG.verifyNote\n ) s = s.trim() + \"\\n\\n\" + CONFIG.verifyNote;\n return { text: s.trim(), wantsTopic, wantsYesNo, attachRef };\n}\n\n/* ---------- WhatsApp Graph API senders ---------- */\nasync function waSend(phoneId, payload) {\n const pid = phoneId || PHONE_ID;\n try {\n const r = await fetch(`https://graph.facebook.com/${GV}/${pid}/messages`, {\n method: \"POST\",\n headers: {\n \"content-type\": \"application/json\",\n Authorization: `Bearer ${TOKEN}`,\n },\n body: JSON.stringify(\n Object.assign({ messaging_product: \"whatsapp\" }, payload),\n ),\n });\n if (!r.ok) console.log(\"waSend error\", r.status, await r.text());\n } catch (e) {\n console.log(\"waSend threw\", String(e));\n }\n}\nfunction sendText(phoneId, to, body) {\n return waSend(phoneId, {\n to,\n type: \"text\",\n text: { preview_url: false, body: body.slice(0, 4000) },\n });\n}\nfunction sendButtons(phoneId, to, body, buttons) {\n return waSend(phoneId, {\n to,\n type: \"interactive\",\n interactive: {\n type: \"button\",\n body: { text: body.slice(0, 1024) },\n action: {\n buttons: buttons.map((b) => ({\n type: \"reply\",\n reply: { id: b.id, title: b.title.slice(0, 20) },\n })),\n },\n },\n });\n}\n/* Shorten a topic to fit WhatsApp's 24-char row title WITHOUT hardcoding any topic name (the topic\n list is committee-maintained and dynamic). Trim at the last word boundary under the limit and add\n an ellipsis so it reads as deliberately shortened rather than mid-word garbage. The FULL name goes\n in the row description (72 chars), which WhatsApp shows in grey beneath the title, so nothing is\n lost. TOPIC_ROWS remains an optional hand-tuned override, but is no longer required for a clean label. */\nfunction shortLabel(s) {\n s = String(s || \"\").trim();\n if (s.length <= 24) return s;\n var cut = s.slice(0, 23);\n var sp = cut.lastIndexOf(\" \");\n if (sp >= 12) cut = cut.slice(0, sp); // prefer a word boundary, but not too short\n return cut.replace(/[\\s\\/,&(-]+$/, \"\") + \"\\u2026\";\n}\nfunction topicRow(t) {\n const full = String(t);\n const ov = TOPIC_ROWS.find((r) => r.id === t); // optional curated override, if the committee wants one\n if (ov) {\n const row = { id: t, title: ov.title.slice(0, 24) };\n row.description = (ov.description || (full.length > 24 ? full : \"\")).slice(\n 0,\n 72,\n );\n return row;\n }\n const row = { id: t, title: shortLabel(full) };\n if (full.length > 24) row.description = full.slice(0, 72); // show the full name when the title was shortened\n return row;\n}\nasync function sendTopicList(phoneId, to, body, page) {\n page = page || 0;\n const all = await getTopics();\n const PER = 9; // 9 topics + 1 \"More\" row = WhatsApp's 10-row cap\n const start = page * PER;\n const slice = all.slice(start, start + PER);\n const rows = slice.map(topicRow);\n const more = all.length > start + PER;\n if (more) {\n rows.push({\n id: \"MORE::\" + (page + 1),\n title: \"More areas\\u2026\",\n description: \"See the remaining areas\",\n });\n }\n return waSend(phoneId, {\n to,\n type: \"interactive\",\n interactive: {\n type: \"list\",\n body: { text: body.slice(0, 1024) },\n action: {\n button: \"Choose area\",\n sections: [{ title: page ? \"More areas\" : \"Areas\", rows }],\n },\n },\n });\n}\n\nfunction sendStarList(phoneId, to, body) {\n const rows = [\n {\n id: \"STAR::5\",\n title: \"\\u2B50\\u2B50\\u2B50\\u2B50\\u2B50\",\n description: \"Excellent \\u2014 it works really well\",\n },\n {\n id: \"STAR::4\",\n title: \"\\u2B50\\u2B50\\u2B50\\u2B50\",\n description: \"Good, with room to improve\",\n },\n {\n id: \"STAR::3\",\n title: \"\\u2B50\\u2B50\\u2B50\",\n description: \"Okay \\u2014 useful sometimes\",\n },\n { id: \"STAR::2\", title: \"\\u2B50\\u2B50\", description: \"Needs work\" },\n { id: \"STAR::1\", title: \"\\u2B50\", description: \"Not useful to me\" },\n ];\n return waSend(phoneId, {\n to,\n type: \"interactive\",\n interactive: {\n type: \"list\",\n body: { text: body.slice(0, 1024) },\n action: { button: \"Rate it\", sections: [{ title: \"Out of 5\", rows }] },\n },\n });\n}\n\n/* ---------- inbound image -> base64 (for forwarding to Drive) ---------- */\nfunction toBase64(bytes) {\n let binary = \"\";\n const chunk = 0x8000;\n for (let i = 0; i < bytes.length; i += chunk) {\n binary += String.fromCharCode.apply(null, bytes.subarray(i, i + chunk));\n }\n return btoa(binary);\n}\nasync function downloadMedia(mediaId) {\n try {\n const meta = await fetch(`https://graph.facebook.com/${GV}/${mediaId}`, {\n headers: { Authorization: `Bearer ${TOKEN}` },\n });\n const mj = await meta.json();\n if (!mj || !mj.url) return null;\n const bin = await fetch(mj.url, {\n headers: { Authorization: `Bearer ${TOKEN}` },\n });\n const buf = new Uint8Array(await bin.arrayBuffer());\n return { base64: toBase64(buf), mime: mj.mime_type || \"image/jpeg\" };\n } catch (e) {\n return null;\n }\n}\n\n/* ---------- per-resident session (Val Town blob, keyed by phone) ---------- */\nasync function loadSession(phone) {\n try {\n const s = await blob.getJSON(WA_PREFIX + phone);\n if (s) return s;\n } catch (e) {}\n return { flat: \"\", history: [], pendingAttachRef: \"\", seen: [] };\n}\nasync function saveSession(phone, s) {\n try {\n await blob.setJSON(WA_PREFIX + phone, s);\n } catch (e) {}\n}\n// so a \"reset\" doesn't force them to re-register.\nasync function resetSession(phone) {\n const flat = (await loadSession(phone)).flat || \"\";\n const fresh = { flat: flat, history: [], pendingAttachRef: \"\", seen: [] };\n await saveSession(phone, fresh);\n return fresh;\n}\nfunction isReset(t) {\n const s = String(t || \"\").trim().toLowerCase().replace(/[.!]+$/, \"\");\n return s === \"reset\" || s === \"restart\" || s === \"start over\" ||\n s === \"new chat\" || s === \"clear chat\" || s === \"forget\";\n}\n\n/* ---------- duplicate-delivery guard ----------\n Meta redelivers a webhook if it doesn't get a 200 quickly, and a rules answer (document fetch +\n several model turns) easily outruns that. The old guard lived inside handleMessage, which loads\n the session at the start and saves it at the end - so two concurrent deliveries both read a\n session that didn't yet list the id, and both answered. That is why residents saw the same\n question answered three or four times.\n The claim below happens BEFORE any slow work: an in-memory set catches redeliveries that land on\n the same warm isolate (the common case), and a blob key catches the rest. */\nconst INFLIGHT = new Set();\nconst DONE = new Map(); // id -> time we finished answering it\nconst STALE_MS = 45000; // below the platform request timeout, so a killed attempt is retried rather than swallowed\nfunction pruneDone() {\n const cutoff = Date.now() - 600000;\n for (const [k, t] of DONE) if (t < cutoff) DONE.delete(k);\n}\nasync function claimMessage(id) {\n if (!id) return true;\n pruneDone();\n if (INFLIGHT.has(id) || DONE.has(id)) return false;\n const key = \"wa_seen_\" + id;\n try {\n const prior = await blob.getJSON(key);\n if (prior) {\n if (prior.done) {\n DONE.set(id, Date.now());\n return false;\n }\n if (Date.now() - (prior.t || 0) < STALE_MS) return false;\n console.log(\"previous attempt did not finish, retrying\", id);\n }\n await blob.setJSON(key, { t: Date.now(), done: false });\n } catch (e) { /* blob unavailable: the in-memory guard still holds */ }\n INFLIGHT.add(id);\n return true;\n}\nasync function finishMessage(id, ok) {\n if (!id) return;\n INFLIGHT.delete(id);\n if (ok) {\n DONE.set(id, Date.now());\n try {\n await blob.setJSON(\"wa_seen_\" + id, { t: Date.now(), done: true });\n } catch (e) {}\n } else {\n try {\n await blob.setJSON(\"wa_seen_\" + id, { t: 0, done: false });\n } catch (e) {}\n }\n}\n\n/* ---------- main handler ---------- */\nexport default async function (req) {\n const url = new URL(req.url);\n\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 && token === VERIFY_TOKEN) {\n return new Response(challenge || \"\", {\n status: 200,\n headers: { \"content-type\": \"text/plain\" },\n });\n }\n if (url.searchParams.get(\"warm\") === \"1\") {\n try {\n await loadContext(false);\n } catch (e) {}\n }\n return new Response(NAME + \" WhatsApp webhook is running.\", {\n status: 200,\n headers: { \"content-type\": \"text/plain\" },\n });\n }\n\n if (req.method !== \"POST\") {\n return new Response(\"Method not allowed\", { status: 405 });\n }\n\n let body;\n try {\n body = await req.json();\n } catch (e) {\n return new Response(\"EVENT_RECEIVED\", { status: 200 });\n }\n\n const KEY = Deno.env.get(\"ANTHROPIC_API_KEY\");\n let SYSTEM = \"\";\n try {\n SYSTEM = await getSystem();\n } catch (e) {\n SYSTEM = \"\";\n }\n\n try {\n const entries = Array.isArray(body.entry) ? body.entry : [];\n for (const entry of entries) {\n for (const change of (entry.changes || [])) {\n const value = change.value || {};\n const phoneId = (value.metadata && value.metadata.phone_number_id) ||\n PHONE_ID;\n const messages = value.messages || []; // absent for delivery-status callbacks\n for (const msg of messages) {\n if (!(await claimMessage(msg.id))) {\n console.log(\"duplicate delivery ignored\", msg.id);\n continue;\n }\n let ok = false;\n try {\n await handleMessage(msg, phoneId, KEY, SYSTEM);\n ok = true;\n } catch (err) {\n console.log(\"handleMessage failed\", msg.id, String(err));\n try {\n await sendText(\n phoneId,\n msg.from,\n \"Sorry \\u2014 something went wrong on my side answering that. Please send it again.\",\n );\n } catch (e2) {}\n } finally {\n await finishMessage(msg.id, ok);\n }\n }\n }\n }\n } catch (e) {\n console.log(\"handler error\", String(e));\n }\n\n // Always 200 quickly so Meta doesn't retry.\n return new Response(\"EVENT_RECEIVED\", { status: 200 });\n}\n\nfunction isGreeting(t) {\n return /^(hi+|hey+|hello+|hii+|yo|start|menu|help|main menu|namaste|namaskara|namaskar)\\W*$/i\n .test(String(t || \"\").trim());\n}\nfunction isLangCmd(t) {\n const s = String(t || \"\").trim().toLowerCase();\n return s === \"language\" || s === \"lang\" || s === \"\\u092d\\u093e\\u0937\\u093e\" ||\n s === \"\\u0cad\\u0cbe\\u0cb7\\u0cc6\";\n}\nfunction isWhatsNew(t) {\n const s = String(t || \"\").trim().toLowerCase();\n return s === \"what's new\" || s === \"whats new\" || s === \"what is new\" ||\n s === \"version\" || s === \"updates\" || s === \"release notes\";\n}\nfunction isAbout(t) {\n const s = String(t || \"\").trim().toLowerCase();\n return s === \"about\" || s === \"about this assistant\" ||\n s === \"about askaoaoa\" || s === \"who built this\" || s === \"who made this\";\n}\nfunction isFeedbackCmd(t) {\n const s = String(t || \"\").trim().toLowerCase().replace(/[?.!]+$/, \"\");\n return s === \"feedback\" || s === \"give feedback\" || s === \"share feedback\" ||\n s === \"send feedback\" || s === \"leave feedback\";\n}\nfunction isMyComplaints(t) {\n const s = String(t || \"\").trim().toLowerCase();\n return /^(my complaints?|complaints? status|status of (my )?complaints?|check (my )?complaints?|complaint status)\\W*$/\n .test(s);\n}\nfunction formatComplaints(list) {\n if (!list || !list.length) {\n return \"You don't have any complaints on record yet. To raise one, just describe the problem and I'll log it for you.\";\n }\n const icon = (st) => {\n const l = String(st || \"\").toLowerCase();\n if (\n l.indexOf(\"resolv\") >= 0 || l.indexOf(\"close\") >= 0 ||\n l.indexOf(\"done\") >= 0\n ) return \"\\u2705\";\n if (l.indexOf(\"progress\") >= 0 || l.indexOf(\"working\") >= 0) {\n return \"\\uD83D\\uDD27\";\n }\n return \"\\uD83D\\uDD52\";\n };\n let out = \"*Your complaints*\";\n for (const c of list) {\n out += \"\\n\\n\" + icon(c.status) + \" *\" + (c.status || \"Open\") + \"* \\u2014 \" +\n (c.category || \"\") + \"\\n_\" + (c.reference || \"\") + \"_\\n\" +\n (c.issue || \"\");\n }\n out += \"\\n\\nThe committee updates these as they work on them.\";\n return out;\n}\nconst ABOUT_TEXT = \"*About \" + NAME + \"*\\n\\n\" + NAME +\n \" is a resident-built assistant for the \" + CONFIG.estateShort +\n \" community. It answers questions from the association's official documents \\u2014 the registered bye-laws, the Rule Book, and the Party Hall and Parking rules \\u2014 and points you to the exact clause or section.\\n\\nYou can also suggest an improvement, share feedback or a concern, or escalate an unresolved MyGate issue to the committee. Anything you share is recorded privately for the committee only \\u2014 never made public.\\n\\nIt works in English, \\u0939\\u093f\\u0902\\u0926\\u0940 and \\u0c95\\u0ca8\\u0ccd\\u0ca8\\u0ca1, on both the web and WhatsApp.\\n\\nYou can also ask for \\u2014 and share \\u2014 recommendations for anything nearby: a dentist, hospital, hardware shop, restaurant, hotel, plumber, tutor, and more.\\n\\nIt uses an AI model restricted to the association's documents, so answers stay grounded in what the community has adopted. Replies are AI-generated and can occasionally be wrong, so please confirm anything important with the Managing Committee.\\n\\n_\" +\n CONFIG.credit + \"_\";\nconst COPILOT_INTRO =\n \"*Committee Copilot* \\u2014 you're now in committee mode. \\uD83D\\uDD10\\n\\nAsk me things like:\\n\\u2022 Summarise this week's complaints\\n\\u2022 Which complaints are still open?\\n\\u2022 Recurring suggestions from residents\\n\\u2022 Draft a notice about the water schedule\\n\\nType *exit* to return to the normal assistant.\";\n\nconst STARTER_ROWS = [\n {\n id: \"ASK::I'd like to suggest an improvement for the community.\",\n title: \"Suggest an improvement\",\n },\n {\n id: \"ASK::I'd like to raise or escalate an issue.\",\n title: \"Raise or escalate issue\",\n },\n {\n id: \"ASK::I have a question for the Managing Committee.\",\n title: \"Ask the committee\",\n },\n {\n id: \"ASK::What are the rules for keeping a pet in the complex?\",\n title: \"Pet / dog rules\",\n },\n { id: \"ASK::What are the gym timings?\", title: \"Gym timings\" },\n {\n id: \"ASK::How do I book the party hall and what does it cost?\",\n title: \"Book the party hall\",\n },\n {\n id: \"ASK::What are the rules and charges for guest parking?\",\n title: \"Guest parking rules\",\n },\n {\n id: \"ASK::What local services do residents recommend?\",\n title: \"Local recommendations\",\n },\n { id: \"CMD::mycomplaints\", title: \"My complaints\" },\n { id: \"ASK::about\", title: \"About this assistant\" },\n];\nasync function sendMenu(phoneId, from, lead) {\n const body = (lead ? lead + \"\\n\\n\" : \"\") +\n \"You can check our community rules, share a suggestion, raise or escalate an issue, or send a question to the Managing Committee. Tap an option below, or just type what you need.\";\n await waSend(phoneId, {\n to: from,\n type: \"interactive\",\n interactive: {\n type: \"list\",\n body: { text: body.slice(0, 1024) },\n action: {\n button: \"See examples\",\n sections: [{\n title: \"Try asking\",\n rows: STARTER_ROWS.map((r) => ({\n id: r.id,\n title: r.title.slice(0, 24),\n })),\n }],\n },\n },\n });\n}\nasync function sendLangMenu(phoneId, from) {\n await sendButtons(\n phoneId,\n from,\n \"Which language would you like replies in? You can also just write in your language and I'll follow.\",\n [\n { id: \"lang_en\", title: \"English\" },\n { id: \"lang_hi\", title: \"\\u0939\\u093f\\u0902\\u0926\\u0940\" },\n { id: \"lang_kn\", title: \"\\u0c95\\u0ca8\\u0ccd\\u0ca8\\u0ca1\" },\n ],\n );\n}\n\n/* ---------- shared contact cards (WhatsApp \"contacts\" message type) ----------\n A resident can attach a phone contact instead of typing the details. Meta delivers it as\n msg.contacts = [{ name:{formatted_name,...}, phones:[{phone,wa_id}], org:{company,title},\n emails:[{email}], addresses:[{city,...}], urls:[{url}] }]. We flatten each card into plain\n text and hand it to the model as a normal turn, so the usual recommendation flow still runs\n (it asks what kind of service it is, and asks consent before crediting the flat). */\nfunction describeContacts(list) {\n const cards = (Array.isArray(list) ? list : []).slice(0, 5); // ignore absurdly large shares\n const out = [];\n for (const c of cards) {\n if (!c) continue;\n const bits = [];\n const nm = (c.name && (c.name.formatted_name ||\n [c.name.first_name, c.name.last_name].filter(Boolean).join(\" \"))) || \"\";\n if (nm) bits.push(\"Name: \" + nm);\n const phones = (c.phones || []).map((p) =>\n (p && (p.phone || p.wa_id)) || \"\"\n ).filter(Boolean);\n if (phones.length) bits.push(\"Phone: \" + phones.join(\", \"));\n const emails = (c.emails || []).map((e) => (e && e.email) || \"\").filter(\n Boolean,\n );\n if (emails.length) bits.push(\"Email: \" + emails.join(\", \"));\n if (c.org && (c.org.company || c.org.title)) {\n bits.push(\n \"Business/role: \" +\n [c.org.company, c.org.title].filter(Boolean).join(\" \\u2014 \"),\n );\n }\n const areas = (c.addresses || []).map((a) => {\n if (!a) return \"\";\n return [a.street, a.city, a.state].filter(Boolean).join(\", \");\n }).filter(Boolean);\n if (areas.length) bits.push(\"Address/area: \" + areas.join(\" | \"));\n const urls = (c.urls || []).map((u) => (u && u.url) || \"\").filter(Boolean);\n if (urls.length) bits.push(\"Website: \" + urls.join(\", \"));\n if (bits.length) out.push(bits.join(\" | \"));\n }\n return out;\n}\n\nasync function handleMessage(msg, phoneId, KEY, SYSTEM) {\n const from = msg.from;\n if (!from) return;\n const session = await loadSession(from);\n\n session.seen = session.seen || [];\n if (session.seen.includes(msg.id)) return;\n session.seen.push(msg.id);\n if (session.seen.length > 30) session.seen = session.seen.slice(-30);\n\n if (msg.type === \"image\") {\n if (session.pendingAttachRef) {\n const media = msg.image && msg.image.id\n ? await downloadMedia(msg.image.id)\n : null;\n if (media) {\n const res = await postSheet({\n type: \"attachment\",\n reference: session.pendingAttachRef,\n data: media.base64,\n mime: media.mime,\n filename: \"whatsapp-photo.jpg\",\n });\n await sendText(\n phoneId,\n from,\n res.ok\n ? \"Thanks \\u2014 I've attached your photo to the escalation and shared it with the committee. \\u2705\"\n : \"I couldn't attach that photo just now. Please try sending it again.\",\n );\n if (res.ok) session.pendingAttachRef = \"\";\n } else {\n await sendText(\n phoneId,\n from,\n \"I couldn't download that image. Please try sending it again.\",\n );\n }\n } else {\n await sendText(\n phoneId,\n from,\n \"Thanks for the photo. If it's for an issue you'd like the committee to see, first escalate the issue, then send the photo and I'll attach it.\",\n );\n }\n await saveSession(from, session);\n return;\n }\n\n let text = \"\";\n if (msg.type === \"text\") {\n text = (msg.text && msg.text.body) || \"\";\n } else if (msg.type === \"contacts\") {\n const cards = describeContacts(msg.contacts);\n if (!cards.length) {\n await sendText(\n phoneId,\n from,\n \"That contact card came through empty on my side. Could you type the name and number instead?\",\n );\n await saveSession(from, session);\n return;\n }\n if (!session.flat) {\n await sendText(\n phoneId,\n from,\n \"Thanks for sharing that contact! \\uD83D\\uDCC7 Before I save it, please reply with your flat number and block (\" +\n BLOCKLIST + \").\",\n );\n await saveSession(from, session);\n return;\n }\n text = \"[CONTACT CARD SHARED] The resident attached \" +\n (cards.length > 1\n ? cards.length + \" phone contacts\"\n : \"a phone contact\") +\n \" from their phone:\\n\" + cards.map((c, i) =>\n (cards.length > 1 ? (i + 1) + \". \" : \"\") + c\n ).join(\"\\n\");\n } else if (msg.type === \"interactive\") {\n const it = msg.interactive || {};\n if (it.type === \"list_reply\" && it.list_reply) {\n const lid = it.list_reply.id || \"\";\n if (lid.indexOf(\"CMD::mycomplaints\") === 0) text = \"my complaints\"; // deterministic complaint lookup\n else if (lid.indexOf(\"MORE::\") === 0) {\n const page = parseInt(lid.slice(6), 10) || 1;\n await sendTopicList(phoneId, from, \"More areas to choose from:\", page);\n await saveSession(from, session);\n return;\n } else if (lid.indexOf(\"ASK::\") === 0) text = lid.slice(5); // starter question\n else if (lid.indexOf(\"STAR::\") === 0) {\n const n = lid.slice(6);\n text = \"Feedback about this assistant: I'd rate it \" + n +\n \" out of 5 stars.\";\n } else text = \"Topic: \" + (lid || it.list_reply.title || \"\"); // topic pick\n } else if (it.type === \"button_reply\" && it.button_reply) {\n const id = (it.button_reply.id || \"\").toLowerCase();\n if (id === \"menu_ask\") {\n await sendText(\n phoneId,\n from,\n \"Sure \\u2014 just type your question. For example: *What are the gym timings?* or *How much does it cost to book the party hall?*\",\n );\n await saveSession(from, session);\n return;\n } else if (id === \"menu_suggest\") {\n text = \"I'd like to suggest an improvement for the community.\";\n } else if (id === \"menu_issue\") {\n text = \"I'd like to raise or escalate an issue.\";\n } else if (id === \"fb_agent\") {\n await sendStarList(\n phoneId,\n from,\n \"Thanks! \\uD83D\\uDE4F How would you rate \" + NAME + \" so far?\",\n );\n await saveSession(from, session);\n return;\n } else if (id === \"fb_community\") {\n text = \"I'd like to share feedback or a concern about the community.\";\n } else if (id === \"lang_en\" || id === \"lang_hi\" || id === \"lang_kn\") {\n session.lang = id.slice(5);\n const conf = session.lang === \"hi\"\n ? \"\\u0939\\u094b \\u0917\\u092f\\u093e \\u2014 \\u092e\\u0948\\u0902 \\u0905\\u092c \\u0939\\u093f\\u0902\\u0926\\u0940 \\u092e\\u0947\\u0902 \\u091c\\u0935\\u093e\\u092c \\u0926\\u0942\\u0901\\u0917\\u093e\\u0964\"\n : session.lang === \"kn\"\n ? \"\\u0c86\\u0caf\\u0cbf\\u0ca4\\u0cc1 \\u2014 \\u0ca8\\u0cbe\\u0ca8\\u0cc1 \\u0c87\\u0ca8\\u0ccd\\u0ca8\\u0cc1 \\u0c95\\u0ca8\\u0ccd\\u0ca8\\u0ca1\\u0ca6\\u0cb2\\u0ccd\\u0cb2\\u0cbf \\u0c89\\u0ca4\\u0ccd\\u0ca4\\u0cb0\\u0cbf\\u0cb8\\u0cc1\\u0ca4\\u0ccd\\u0ca4\\u0cc7\\u0ca8\\u0cc6.\"\n : \"Done \\u2014 I'll reply in English.\";\n await sendText(phoneId, from, conf);\n await saveSession(from, session);\n return;\n } else {\n text = id === \"yes\"\n ? \"Yes\"\n : id === \"no\"\n ? \"No\"\n : (it.button_reply.title || \"\");\n }\n }\n } else {\n await sendText(\n phoneId,\n from,\n \"I can read text messages, photos and shared contact cards. Please type your question, or tap one of the options I send.\",\n );\n await saveSession(from, session);\n return;\n }\n text = String(text || \"\").trim();\n if (!text) {\n await saveSession(from, session);\n return;\n }\n\n const DEV = (Deno.env.get(\"DEV_NUMBERS\") || \"\").split(\",\").map((x) =>\n x.trim()\n ).filter(Boolean);\n if (DEV.includes(from)) {\n const dlow = text.trim().toLowerCase();\n if (dlow === \"reset sessions\" || dlow === \"reset all sessions\") {\n await sendText(\n phoneId,\n from,\n \"\\u26A0\\uFE0F This will erase EVERY resident's saved flat and chat memory, so everyone re-onboards from scratch. It does NOT touch the Google Sheet or any logged data. To proceed, reply exactly: reset sessions confirm\",\n );\n await saveSession(from, session);\n return;\n }\n if (dlow === \"reset sessions confirm\") {\n let n = 0;\n try {\n const keys = await blob.list(WA_PREFIX);\n for (const k of keys) {\n const key = (typeof k === \"string\") ? k : k.key;\n if (key) {\n try {\n await blob.delete(key);\n n++;\n } catch (e) {}\n }\n }\n } catch (e) {}\n await sendText(\n phoneId,\n from,\n \"\\u2705 Done \\u2014 cleared \" + n +\n \" resident session(s). Everyone will be greeted fresh and asked for their flat again.\",\n );\n return;\n }\n }\n\n const MC = (Deno.env.get(\"MC_NUMBERS\") || \"\").split(\",\").map((x) => x.trim())\n .filter(Boolean);\n if (MC.includes(from)) {\n const low = text.trim().toLowerCase();\n if (\n session.mode !== \"copilot\" &&\n (low === \"copilot\" || low === \"mc\" || low === \"committee\" ||\n low === \"mc mode\")\n ) {\n session.mode = \"copilot\";\n session.chist = [];\n await sendText(phoneId, from, COPILOT_INTRO);\n await saveSession(from, session);\n return;\n }\n if (session.mode === \"copilot\") {\n if (\n /^(exit|done|resident|leave|quit|end|back|stop)(\\s+copilot|\\s+mode)?$/\n .test(low)\n ) {\n session.mode = \"\";\n session.chist = [];\n await sendText(\n phoneId,\n from,\n 'Left committee copilot \\u2014 back to the normal assistant. Say \"copilot\" anytime to return.',\n );\n await saveSession(from, session);\n return;\n }\n session.chist = session.chist || [];\n session.chist.push({ role: \"user\", content: text });\n const rep = await copilotAnswer(KEY, session.chist, SYSTEM);\n session.chist.push({ role: \"assistant\", content: rep });\n if (session.chist.length > 14) session.chist = session.chist.slice(-14);\n const outMsg = rep.replace(/\\*\\*(.+?)\\*\\*/g, \"*$1*\");\n await sendText(\n phoneId,\n from,\n outMsg.length > 3900\n ? outMsg.slice(0, 3900) +\n \"\\n\\n(\\u2026truncated \\u2014 ask for a specific part)\"\n : outMsg,\n );\n await saveSession(from, session);\n return;\n }\n }\n\n const OPS = (Deno.env.get(\"OPS_NUMBERS\") || \"\").split(\",\").map((x) =>\n x.trim()\n ).filter(Boolean);\n if (OPS.includes(from)) {\n const low = text.trim().toLowerCase();\n\n // list active alerts (numbered)\n if (\n low === \"status\" || low === \"status list\" || low === \"list status\" ||\n low === \"statuses\"\n ) {\n const d = await sheetGet(\"q=status\", 10000);\n const active = (d && d.ok && Array.isArray(d.active)) ? d.active : [];\n if (!active.length) {\n await sendText(\n phoneId,\n from,\n \"No site alerts are active right now.\\n\\nPost one with: status: \",\n );\n } else {\n let m = \"*Active site alerts*\";\n active.forEach((a, i) => {\n m += \"\\n\" + (i + 1) + \". \" + a.message;\n });\n m +=\n '\\n\\nSend \"clear \" to remove one, or \"clear all\" to remove all.';\n await sendText(phoneId, from, m);\n }\n await saveSession(from, session);\n return;\n }\n\n // clear ALL\n if (\n low === \"clear all\" || low === \"all clear\" || low === \"clear status\" ||\n low === \"status clear\"\n ) {\n await postSheet({ type: \"status_clear\" });\n await invalidateContext();\n await invalidatePreflight();\n await sendText(\n phoneId,\n from,\n \"\\u2705 All site alerts cleared \\u2014 residents will no longer see any active alert.\",\n );\n await saveSession(from, session);\n return;\n }\n\n // clear ONE by number\n const cm = low.match(/^clear\\s+(\\d+)$/);\n if (cm) {\n const n = parseInt(cm[1], 10);\n const d = await sheetGet(\"q=status\", 10000);\n const active = (d && d.ok && Array.isArray(d.active)) ? d.active : [];\n if (n < 1 || n > active.length) {\n await sendText(\n phoneId,\n from,\n \"There's no alert #\" + n +\n '. Send \"status list\" to see the current alerts and their numbers.',\n );\n } else {\n const target = active[n - 1];\n await postSheet({ type: \"status_clear\", row: target.row });\n await invalidateContext();\n await invalidatePreflight();\n await sendText(\n phoneId,\n from,\n \"\\u2705 Cleared alert #\" + n + \":\\n\\n\" + target.message +\n (active.length > 1\n ? '\\n\\nThe other alert(s) are still active \\u2014 send \"status list\" to review.'\n : \"\"),\n );\n }\n await saveSession(from, session);\n return;\n }\n\n // add a NEW alert\n const mset = text.match(/^\\s*(?:post\\s+)?status\\s*[:\\-]\\s*([\\s\\S]+)$/i);\n if (mset) {\n const msg = mset[1].trim();\n const res = await postSheet({\n type: \"status_set\",\n message: msg,\n postedBy: from,\n });\n await invalidateContext();\n await invalidatePreflight();\n const num = (res && res.count) ? res.count : null;\n await sendText(\n phoneId,\n from,\n res.ok\n ? (\"\\u2705 Posted\" + (num ? \" as alert #\" + num : \"\") + \":\\n\\n\" +\n msg +\n '\\n\\nResidents asking about power, water or lifts will now be told this.\\nSend \"status list\" to see all, \"clear ' +\n (num || \"\") + '\" to remove this one, or \"clear all\".')\n : \"Couldn't post that just now. Please try again.\",\n );\n await saveSession(from, session);\n return;\n }\n }\n\n // ---- first-time onboarding: ask for and store the flat number ----\n if (!session.flat) {\n if (isValidFlat(text)) {\n session.flat = normalizeFlat(text);\n await sendText(\n phoneId,\n from,\n \"Thanks! You're set as flat *\" + session.flat +\n \"*. \\uD83D\\uDC4B\\n\\nI'm \" + NAME +\n \", your line to the Managing Committee. You can check our community rules, share a suggestion, raise or escalate an issue, or ask the committee a question. \" +\n DISCLAIMER,\n );\n await sendMenu(phoneId, from, \"\");\n await saveSession(from, session);\n return;\n }\n const greeting =\n /^(hi+|hello|hey|hai|start|menu|hola|namaste|namaskara|good\\s*(morning|afternoon|evening))\\b/i\n .test(text.trim());\n if (greeting || text.trim().length < 2) {\n await sendText(\n phoneId,\n from,\n \"Welcome to *\" + NAME + \"*, the \" + CONFIG.estateShort +\n \" community assistant.\\n\\nTo get started, please reply with your flat number and block (\" +\n BLOCKLIST + \").\",\n );\n } else {\n await sendText(\n phoneId,\n from,\n \"Hmm, that doesn't match a flat at \" + CONFIG.estateShort +\n \". Please reply with a valid \" + CONFIG.estateShort +\n \" flat to continue.\",\n );\n }\n await saveSession(from, session);\n return;\n }\n\n // ---- quick commands (once onboarded) ----\n if (isReset(text)) {\n const fresh = await resetSession(from);\n await sendText(\n phoneId,\n from,\n fresh.flat\n ? \"Done \\u2014 I've cleared our conversation. You're still registered as flat \" +\n fresh.flat + \". What can I help you with?\"\n : \"Done \\u2014 I've cleared our conversation. What can I help you with?\",\n );\n return;\n }\n if (isGreeting(text)) {\n await sendMenu(phoneId, from, \"Hello! \\uD83D\\uDC4B\");\n await saveSession(from, session);\n return;\n }\n if (isLangCmd(text)) {\n await sendLangMenu(phoneId, from);\n await saveSession(from, session);\n return;\n }\n if (isWhatsNew(text)) {\n await sendText(phoneId, from, RELEASES_TEXT);\n await saveSession(from, session);\n return;\n }\n if (isAbout(text)) {\n await sendText(phoneId, from, ABOUT_TEXT);\n await saveSession(from, session);\n return;\n }\n if (isFeedbackCmd(text)) {\n session.fbNudged = true; // they've come to it themselves; don't nudge later\n await sendButtons(\n phoneId,\n from,\n \"Happy to take that \\u2014 which kind of feedback is it?\",\n [\n { id: \"fb_agent\", title: \"About this assistant\" },\n { id: \"fb_community\", title: \"About the community\" },\n ],\n );\n await saveSession(from, session);\n return;\n }\n if (isMyComplaints(text)) {\n const dc = await sheetGet(\n \"q=complaint&flat=\" + encodeURIComponent(session.flat || \"\"),\n 15000,\n );\n const list = (dc && dc.ok && Array.isArray(dc.complaints))\n ? dc.complaints\n : [];\n await sendText(phoneId, from, formatComplaints(list));\n await saveSession(from, session);\n return;\n }\n if (isComplaintStatus(text)) {\n const cref = complaintRef(text);\n let cq = \"q=complaint&flat=\" + encodeURIComponent(session.flat);\n if (cref) cq += \"&ref=\" + encodeURIComponent(cref);\n const cd = await sheetGet(cq);\n await sendText(phoneId, from, formatComplaintsWA(cd, cref));\n await saveSession(from, session);\n return;\n }\n\n if (!KEY || !SYSTEM) {\n await sendText(\n phoneId,\n from,\n \"The assistant isn't fully set up yet. Please check back shortly.\",\n );\n await saveSession(from, session);\n return;\n }\n\n // ---- run the assistant ----\n session.history = session.history || [];\n session.history.push({ role: \"user\", content: text });\n\n const raw = await answer(\n KEY,\n SYSTEM,\n session.history,\n session.flat,\n session.lang || \"\",\n );\n const fmt = formatForWhatsApp(raw, text);\n const reply = fmt.text,\n wantsTopic = fmt.wantsTopic,\n wantsYesNo = fmt.wantsYesNo,\n attachRef = fmt.attachRef;\n\n session.history.push({\n role: \"assistant\",\n content: raw.replace(/\\[\\[PICK_(DATE|TOPIC|YESNO)\\]\\]/g, \"\").replace(\n /\\[\\[ATTACH:[^\\]]*\\]\\]/g,\n \"\",\n ).trim(),\n });\n if (session.history.length > 16) session.history = session.history.slice(-16);\n if (attachRef) session.pendingAttachRef = attachRef;\n\n if (reply) await sendText(phoneId, from, reply);\n if (attachRef) {\n await sendText(\n phoneId,\n from,\n \"If you'd like, send a photo of the issue here and I'll attach it to the escalation. \\uD83D\\uDCF7\",\n );\n }\n if (wantsTopic) {\n await sendTopicList(\n phoneId,\n from,\n \"Please choose the area this relates to:\",\n );\n } else if (wantsYesNo) {\n await sendButtons(phoneId, from, \"Please choose:\", [{\n id: \"yes\",\n title: \"Yes\",\n }, { id: \"no\", title: \"No\" }]);\n }\n\n session.msgCount = (session.msgCount || 0) + 1;\n if (\n session.msgCount === 3 && !session.recNudged && !wantsTopic &&\n !wantsYesNo && !attachRef\n ) {\n session.recNudged = true;\n await sendText(\n phoneId,\n from,\n \"\\uD83D\\uDCA1 By the way \\u2014 got a favourite nearby you'd recommend to neighbours? A dentist, hospital, hardware shop, restaurant, hotel, plumber \\u2014 anything at all. Just tell me and I'll save it so others in \" +\n CONFIG.estateShort + \" can benefit.\",\n );\n } else if (\n session.msgCount === 8 && !session.fbNudged && !wantsTopic && !wantsYesNo &&\n !attachRef\n ) {\n session.fbNudged = true;\n await sendStarList(\n phoneId,\n from,\n \"Quick one, if you don't mind \\u2014 how would you rate \" + NAME +\n \" so far? Your answer goes only to the Managing Committee and helps them improve it.\",\n );\n }\n\n await saveSession(from, session);\n}","","createdAt",["D",1786024582790],"branchVersion","branchId","aa8a9feb-b453-4de6-a38e-fad95249c5c1","id","5cf5a03d-6202-46e5-9f56-2947582cf7e8","AskAOAOA_Whatsapp",["D",1783664429895],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","Whatsapp chat setup for AskAOAOA","imageUrl","4a18de72-744a-4935-a405-7e9166d2bb8e","pinnedFileId","pinPreview","pinMigrated","screenshotVersion","likeCount",0,"orgId","019f2c5b-c205-7209-90ec-fea27dba2152","tursoName","tursoHostname","tursoMeasuredAt","pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_95":94,"_103":99},"org",{"_95":94,"_96":97,"_98":99,"_18":55,"_100":101,"_102":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",119,"main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","sanair1992","handle","displayName","Shyam A Nair","avatar","https://lh3.googleusercontent.com/a/ACg8ocL6k5_PJu7Okt0TDOcmJDDE1rjDZi65QoH9WtDAlAU6jJixUNUydg=s96-c","tier","free","canRestrictVals","profileImageUrl","branchName","adoptOrgId",{"_43":44,"_32":45,"_38":151,"_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":152,"_79":153,"_81":154,"_83":25},"tree",[146],"files",[146],"counts",{"_134":61,"_135":136,"_137":61,"_138":139,"_140":141},"contents",[126],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles",true,"grants","orgs","customDomains",{},{"_43":127,"_32":28,"_30":31,"_128":-5,"_41":42,"_40":14,"_129":25,"_38":130,"_13":131,"_33":34,"_35":37,"_24":25,"_132":-5,"_27":133},"ed040657-cdf1-4adf-841a-4a613b87571d","parentId","latest",["D",1786024582790],60,"label",[28],"pulls","branches",1,"forks","envVars",{"_142":144,"_145":61},"connections",{"_142":61,"_143":61},"count","unfilledCount",12,"emptyCount",{"_43":127,"_32":28,"_30":31,"_128":-5,"_41":42,"_40":14,"_129":25,"_38":147,"_13":131,"_33":34,"_35":37,"_24":25,"_132":-5,"_148":149,"_27":150},["D",1786024582790],"children",[],[28],["D",1783664429895],{"_95":94,"_103":99},{"_95":94,"_96":97,"_98":99,"_18":55,"_100":101,"_102":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,"_123":188,"_189":190,"_191":192,"_193":25,"_194":25,"_195":25,"_196":121,"_197":-5,"_198":-7,"_199":-7,"_200":61,"_201":25,"_202":25,"_203":-5,"_204":25,"_205":25,"_206":25,"_207":-5},"ENV",{"_159":160,"_161":162,"_163":85,"_164":165,"_166":167,"_168":169,"_170":171,"_172":173,"_174":175,"_176":177,"_178":179,"_180":181,"_182":183,"_184":185,"_186":187},"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 · v114