[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_164":165,"_166":167},"routes/_app.x.$handle.$name",{"_97":96,"_32":44,"_106":87,"_27":107,"_13":14,"_108":-5,"_11":109,"_110":111,"_112":113,"_114":115,"_116":117,"_20":-5,"_118":-5,"_119":-5,"_120":48,"_121":122,"_123":25,"_124":-5,"_125":-5,"_126":127},"routes/_app.x.$handle.$name.branch.$branch.version.$version.diff",{"_11":12,"_13":14,"_15":16,"_17":-5,"_18":-5},"project",{"_42":43,"_32":44,"_37":45,"_46":-5,"_47":48,"_49":50,"_51":50,"_52":53,"_54":-5,"_18":55,"_56":-5,"_57":48,"_58":-5,"_59":-5,"_60":61,"_62":63,"_64":65,"_66":67,"_68":69,"_70":-5,"_71":72,"_73":72,"_74":75,"_76":75,"_77":75,"_78":72,"_79":72,"_80":81,"_82":83,"_84":85,"_86":48},"version",107,"changes",[19],"aiChatInfo","userId",{"_20":21,"_22":23,"_24":25,"_26":25,"_27":28,"_29":28},"file",{"_30":31,"_32":28,"_33":34,"_35":36,"_37":38,"_39":14,"_40":41,"_24":25},"previous",{"_30":31,"_32":28,"_33":34,"_35":36},"deleted",true,"deletedHere","path","askaoaoa-config.ts","latestPath","fileId","e630533a-8a88-11f1-95ce-1607ee4eb77e","name","fileType","script","content","// AskAOAOA — CONFIG val (Val Town Script val, Unlisted). ONE per community.\n//\n// This is the ONLY file that changes from one apartment to the next. The knowledge val\n// (rules) and the two app vals (web + WhatsApp) read everything community-specific from here,\n// so a new community = a new copy of this file + its own Sheet / Drive folder / WhatsApp number.\n//\n// The app vals import this via their CONFIG_URL env var (set it to this val's ES-module URL,\n// e.g. https://esm.town/v//askaoaoa_config).\n//\n// To rename the assistant: change `name` below (and regenerate the page val for the web branding).\n\nexport const CONFIG = {\n id: \"aryan-opulence\", // slug; used only for internal namespacing\n name: \"AskAOAOA\", // assistant display name\n association: \"Aryan Opulence Apartment Owners' Association\",\n estateShort: \"Aryan Opulence\", // short name used in messages\n unitCount: 189,\n languages: [\"English\", \"Hindi\", \"Kannada\"], // offered languages, in order\n fmsContact: \"Sandeep on +91 91108 02505\", // FMS (facility) manager, quoted to residents on escalations\n disclaimer:\n \"_I'm an AI assistant and can occasionally be wrong \\u2014 please verify anything important with the Managing Committee._\",\n // Appended to any answer that carries a VERDICT line, so a screenshot of it never travels\n // without context. Keep it short: it rides along on real answers.\n verifyNote:\n \"_This is general information from the association's documents, not a ruling. The committee may have since decided otherwise \\u2014 please check with them._\",\n credit: \"Built by Shyam A Nair (602-C), as a community volunteer effort.\", // shown in the web + WhatsApp About\n\n // Flat scheme — replaces the old hardcoded isValidFlat(). Accepts \"602-C\" or \"C-602\":\n // the last two digits are the flat, the leading digit(s) are the floor \"series\".\n flats: {\n blocks: [\"a\", \"b\", \"c\", \"d\"],\n limits: {\n a: { maxSeries: 11, maxFlat: 6 },\n b: { maxSeries: 11, maxFlat: 4 },\n c: { maxSeries: 10, maxFlat: 4 },\n d: { maxSeries: 10, maxFlat: 4 },\n },\n },\n\n // FALLBACK topic list only. Topics now derive from the MC Contacts Portfolio rows (+ \"Others\")\n // via the ?q=topics endpoint; this list is used only if that returns nothing.\n topics: [\n \"Finance\",\n \"Admin & Communication\",\n \"Security/Parking\",\n \"MEP (Mechanical, Electrical, Plumbing)\",\n \"Gardening\",\n \"AMCs & FMS\",\n \"Housekeeping\",\n \"Tech/IT (including MyGate)\",\n \"Water Management\",\n \"Clubhouse Management\",\n \"Others\",\n ],\n\n // Web page brand colours (hex, no \"#\"): header/primary (ink), gradient end (ink2),\n // accent/gold (accent), and muted green (sage). Edit these to re-theme the web app.\n brand: { ink: \"16302B\", ink2: \"0F231F\", accent: \"B5852C\", sage: \"5E7168\" },\n\n // LLM routing (mode-based): a cheaper/faster model for the high-volume resident agent,\n // a stronger model for the committee copilot. Flip either back to the same value to undo.\n models: { resident: \"claude-haiku-4-5-20251001\", copilot: \"claude-sonnet-5\" },\n};\n\n// ---- Generic flat validation, driven by CONFIG.flats (no per-community code) ----\nfunction flatRegexes(cfg) {\n const cls = ((cfg.flats && cfg.flats.blocks) || []).join(\"\");\n return [\n new RegExp(\"^(\\\\d{3,4})-?([\" + cls + \"])$\"),\n new RegExp(\"^([\" + cls + \"])-?(\\\\d{3,4})$\"),\n ];\n}\nfunction parseFlat(raw, cfg) {\n const s = String(raw || \"\").trim().toLowerCase().replace(/\\s+/g, \"\");\n const [re1, re2] = flatRegexes(cfg);\n const m = s.match(re1) || s.match(re2);\n if (!m) return null;\n let digits, block;\n if (/^\\d/.test(m[1])) {\n digits = m[1];\n block = m[2];\n } else {\n block = m[1];\n digits = m[2];\n }\n return {\n digits,\n block,\n flat: parseInt(digits.slice(-2), 10),\n series: parseInt(digits.slice(0, -2), 10),\n };\n}\nexport function isValidFlat(raw, cfg) {\n cfg = cfg || CONFIG;\n const p = parseFlat(raw, cfg);\n if (!p) return false;\n const lim = (cfg.flats.limits && cfg.flats.limits[p.block]) || {};\n const maxSeries = lim.maxSeries || 99, maxFlat = lim.maxFlat || 99;\n return p.series >= 1 && p.series <= maxSeries && p.flat >= 1 &&\n p.flat <= maxFlat;\n}\nexport function normalizeFlat(raw, cfg) {\n cfg = cfg || CONFIG;\n const p = parseFlat(raw, cfg);\n if (!p) return String(raw || \"\").trim().toUpperCase();\n return (p.digits + \"-\" + p.block).toUpperCase();\n}","createdAt",["D",1785946311391],"branchVersion","branchId","624491c7-35e4-41e1-bcdd-f028e6d18f83","id","7c9f1d75-2ce0-4053-b1a5-371b96e9689a","AskAOAOA",["D",1783155855780],"deletedAt","legacyEnvVars",false,"privacy","public","httpPrivacy","description","AOAOA Chat Assistant","imageUrl","4a18de72-744a-4935-a405-7e9166d2bb8e","pinnedFileId","pinPreview","pinMigrated","screenshotVersion","likeCount",0,"orgId","019f2c5b-c205-7209-90ec-fea27dba2152","tursoName","7c9f1d752ce04053b1a5371b96e9689a","tursoHostname","7c9f1d752ce04053b1a5371b96e9689a-val-town.aws-us-east-2.turso.io","tursoMeasuredAt",["D",1789517443998],"pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_97":96,"_105":101},"org",{"_97":96,"_98":99,"_100":101,"_18":55,"_102":103,"_104":48},"branch",{"_13":14,"_32":87,"_42":41,"_88":43,"_89":-5,"_90":-5,"_91":-5,"_92":-5,"_93":-5,"_94":44,"_95":96},"isOwned","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",{"_42":43,"_32":44,"_37":159,"_46":-5,"_47":48,"_49":50,"_51":50,"_52":53,"_54":-5,"_18":55,"_56":-5,"_57":48,"_58":-5,"_59":-5,"_60":61,"_62":63,"_64":65,"_66":67,"_68":160,"_70":-5,"_71":72,"_73":72,"_74":75,"_76":75,"_77":75,"_78":72,"_79":72,"_80":161,"_82":162,"_84":163,"_86":48},"tree",[154],"files",[154],"counts",{"_142":61,"_143":144,"_145":61,"_146":147,"_148":149},"contents",[128],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},{"_42":129,"_32":130,"_30":131,"_132":-5,"_40":41,"_39":133,"_134":25,"_37":135,"_13":136,"_33":137,"_35":138,"_24":48,"_139":140,"_27":141},"1163b022-ad8d-4f5c-b0e0-e6c69381de8e","askaoaoa.ts","55270802-7787-11f1-b236-1607ee4eb77e","parentId",104,"latest",["D",1785946223442],60,"http","// AskAOAOA — Val Town HTTP val. Env vars: ANTHROPIC_API_KEY, DATA_URL (knowledge val module URL), PAGE_URL (frontend val module URL\n// of your bye-law data val), ACCESS_CODE, SHEET_WEBHOOK_URL, SHEET_SECRET. Sheet link lives only in the Apps Script.\n\n// Bye-law knowledge lives in a separate val; set DATA_URL to its module URL.\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\nimport { blob } from \"https://esm.town/v/std/blob\";\n\n// Web frontend lives in a separate val; set PAGE_URL to its module URL.\nlet PAGE_CACHE = null;\nconst FEEDBACK_WIDGET = `\n\n\n\n\n

How is this assistant working for you?

Goes to the Managing Committee only. It helps them fix what is broken and decide what to add next.

\n\n Rating\n

\n\n What is this about?\n

\n\n In your words\n \n\n \n \n \n Send without my flat number\n \n\n

\n \n \n

\n\n\n`;\n\nasync function getPage() {\n if (PAGE_CACHE != null) return PAGE_CACHE;\n const u = Deno.env.get(\"PAGE_URL\");\n if (!u) {\n throw new Error(\n \"PAGE_URL is not set. Set it to the page val's MODULE url (esm.town/v/...) \\u2014 the same kind of url as DATA_URL, from the val's '\\u22ee \\u2192 Copy module URL' menu. It must NOT be the .val.run endpoint.\",\n );\n }\n if (/\\.val\\.run/i.test(u)) {\n throw new Error(\n \"PAGE_URL looks like a .val.run endpoint (\" + u +\n \"). Use the page val's MODULE url instead: open the page val, '\\u22ee \\u2192 Copy module URL' (esm.town/v/...).\",\n );\n }\n let mod;\n try {\n mod = await import(u);\n } catch (e) {\n throw new Error(\n \"Could not import PAGE_URL (\" + u +\n \"). Check it is the page val's module url and the val is saved. Details: \" +\n (e && e.message ? e.message : e),\n );\n }\n if (!mod || typeof mod.PAGE !== \"string\" || !mod.PAGE) {\n throw new Error(\n 'PAGE_URL imported, but it has no non-empty PAGE export. The page val must contain: export const PAGE = \"...\"; (re-save it and remove any ?v= from the url).',\n );\n }\n // brand the page from CONFIG (case-sensitive; internal ids use lowercase 'aoaoa' and are untouched)\n const B = CONFIG.brand || {};\n PAGE_CACHE = mod.PAGE\n .split(\"AskAOAOA\").join(CONFIG.name)\n .split(\"Aryan Opulence\").join(CONFIG.estateShort)\n .split(\"--ink:#16302B\").join(\"--ink:#\" + (B.ink || \"16302B\"))\n .split(\"--ink-2:#0F231F\").join(\"--ink-2:#\" + (B.ink2 || \"0F231F\"))\n .split(\"--brass:#B5852C\").join(\"--brass:#\" + (B.accent || \"B5852C\"))\n .split(\"--sage:#5E7168\").join(\"--sage:#\" + (B.sage || \"5E7168\"));\n try {\n const _t = await getTopics();\n PAGE_CACHE = PAGE_CACHE.replace(\n /const TOPICS = \\[[\\s\\S]*?\\];/,\n \"const TOPICS = \" + JSON.stringify(_t) + \";\",\n );\n } catch (e) {}\n // Feedback widget is injected here rather than living in the page val, so the frontend HTML never\n // has to change. It reads the access code and last exchange off the /api traffic it wraps, so it\n // needs no knowledge of the page's own markup.\n if (PAGE_CACHE.indexOf(\"aoafb-open\") < 0) {\n const _i = PAGE_CACHE.toLowerCase().lastIndexOf(\"\");\n PAGE_CACHE = (_i >= 0)\n ? (PAGE_CACHE.slice(0, _i) + FEEDBACK_WIDGET + PAGE_CACHE.slice(_i))\n : (PAGE_CACHE + FEEDBACK_WIDGET);\n }\n return PAGE_CACHE;\n}\n\n// ---- per-community config (the config val). Set CONFIG_URL to its ES-module URL. ----\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 NAME = CONFIG.name;\nconst TOPICS = CONFIG.topics;\nconst isValidFlat = (raw) => _cfg.isValidFlat(raw, CONFIG);\nconst normalizeFlat = (raw) => _cfg.normalizeFlat(raw, CONFIG);\n\nlet MANIFEST_CACHE = {}, MANIFEST_TS = {};\nasync function getManifest(mc) {\n const key = mc ? \"mc\" : \"all\";\n const now = Date.now();\n // loadContext (called just before this on the resident path) already fetched q=docs and filled\n // MANIFEST_CACHE. Trust it rather than making a SECOND q=docs call - that duplicate call was the\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\" : \"\"));\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 // txt stays null if the fetch failed (as opposed to \"\" for a genuinely empty library). Don't cache\n // a failure, and signal it to the model so it never says \"no such document\" when it simply couldn't\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\");\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\n// Tool schemas now live in the data val (one shared copy). Fetched and cached like ACTIONS.\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\n// ACTIONS now lives in the data val (one shared copy). Fetched and cached by getActions().\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 // Deterministic misconfiguration, not a transient blip: the data val loaded but is an OLD copy\n // without buildActions (usually DATA_URL pinned to an earlier version). Fail loudly - silently\n // serving an empty ACTIONS would strip every action instruction while still looking healthy.\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(\"web\");\n // Fingerprint the loaded prompt so you can tell from the logs whether the data val you just\n // saved is actually the one being served (a pinned DATA_URL fails silently otherwise).\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\") || \"\";\nconst MC_CODE = Deno.env.get(\"MC_ACCESS_CODE\") || \"\";\nfunction mcAccepts(c) {\n return !!MC_CODE && String(c || \"\").trim() === MC_CODE;\n}\n\nconst RAW_ACCESS = (Deno.env.get(\"ACCESS_CODE\") || \"\").trim();\nlet MODE = \"off\", SHARED = \"\";\nif (RAW_ACCESS.length) {\n if (RAW_ACCESS.toLowerCase() === \"flat\") MODE = \"flat\";\n else {\n MODE = \"code\";\n SHARED = RAW_ACCESS;\n }\n}\nconst gateOn = MODE !== \"off\";\n\nfunction accepts(code) {\n if (MODE === \"off\") return true;\n if (MODE === \"flat\") return isValidFlat(code);\n return String(code || \"\").trim().toLowerCase() === SHARED.toLowerCase();\n}\n\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\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 // Manual redirect handling, same reason as sheetGet. Apps Script 302s a POST to\n // googleusercontent.com; that hop must be followed as a GET (standard 302 behaviour), and Apps\n // Script has already done the write by the time it redirects, so the GET just fetches the result.\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 // Follow Apps Script's redirect MANUALLY. A /exec call answers with a 302 to\n // script.googleusercontent.com, and the runtime's automatic redirect-follower stalls on that hop\n // for the full timeout - the val saw 12s while Google's own Executions page showed the script\n // finishing in ~1.5s. Reading the Location header and fetching it ourselves avoids the stall.\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\n// expiring between questions and re-exposing each cold miss to a slow Apps Script moment. Site alerts\n// still appear at once because posting/clearing status calls invalidateContext().\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 // Merge, don't replace: if only one of the three lookups failed this time (a slow Apps Script\n // moment), keep the last good value for that piece from the cached copy rather than blanking it.\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 // Only stamp a fresh timestamp when ALL three succeeded; a partial merge keeps the old timestamp so\n // it is retried soon rather than treated as a full 30-minute-fresh copy.\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\");\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\nconst SYSTEM_COPILOT = \"You are the \" + NAME +\n \" Committee Copilot for the Managing Committee (MC) of \" +\n CONFIG.estateShort + \" Apartments, a \" + CONFIG.unitCount +\n \"-flat community. You are given recent community data as JSON (complaints with status, suggestions, questions, escalations, site-status posts, neighbour recommendations, and agentFeedback \\u2014 residents' ratings of the assistant itself, rated up/down/mixed with their comment and channel), newest first. Help the committee: summarise and count, spot recurring themes, list open/pending items and prioritise them, report how residents rate the assistant itself (satisfaction trend, common gaps) when asked, and draft clear courteous communications (notices, replies to residents, AGM agenda items). Base everything strictly on the data provided; never invent numbers, references, names, or records; if it is not in the data, say so plainly. Complaint status is in the 'Status' field (Open / In Progress / Resolved); complaints look like AO-C-... Cite references and flats where it helps the committee act. Dates are IST; interpret 'this week' / 'this month' relative to the date given. Be concise and action-oriented; use short bullet lists for summaries and a warm, professional tone for drafts. This data is confidential to the committee. You are advisory \\u2014 you do not send messages or change any records. You can also open any association document from the DOCUMENT LIBRARY with the get_document tool \\u2014 including committee-only data such as boom-barrier/vehicle logs or security attendance \\u2014 to analyze it: summarise, count, find patterns or outliers (for example, which security staff were least punctual last quarter), and cite exact figures. For a rules question you MAY quote exact clause or section numbers to the committee (residents never receive clause numbers).\";\n\nasync function copilotAnswer(KEY, history, sys) {\n const dd = await sheetGet(\"q=export\");\n const dataStr = (dd && dd.ok && dd.data)\n ? JSON.stringify(dd.data)\n : \"(no data available)\";\n const manifest = await getManifest(true); // committee scope: includes committee-only documents\n const system = [\n {\n type: \"text\",\n text: SYSTEM_COPILOT,\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 );\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 formatComplaintsWeb(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. 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 return \"\\u2022 \" + (c.reference || \"\") + \" \\u2014 \" + (c.category || \"\") +\n \": \" + (c.issue || \"\") + \" [Status: \" + (c.status || \"Open\") + \"]\";\n });\n return \"Here's the latest on your complaint\" + (list.length > 1 ? \"s\" : \"\") +\n \":\\n\\n\" + lines.join(\"\\n\");\n}\n\n// Remove bye-law/clause/section NUMBERS from resident-facing replies (keep the plain answer).\nfunction stripCites(t) {\n if (!t) return t;\n let s = String(t);\n // parenthetical citations that contain a clause/section number, e.g. *(Bye-Laws, Clause 3.12)*\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 pick it with the date picker (YYYY-MM-DD).\",\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 pick 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));\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 === \"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: \"Web\",\n });\n }\n if (name === \"get_recommendations\") {\n return await sheetGet(\n \"q=recommend&query=\" + encodeURIComponent(input.query || \"\"),\n );\n }\n if (name === \"get_mc_contacts\") {\n return await sheetGet(\"q=mc\");\n }\n if (name === \"get_document\") {\n // Documents get a much longer budget than the light lookups: on a cold cache Apps Script has to\n // open the file and extract the whole body, which for a big bye-laws document is well past 8s.\n // Once extracted it is cached for 6 hours, so only the first read after a deploy pays this.\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\nasync function callClaude(KEY, systemBlocks, messages) {\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: await getTools(await getTopics()),\n messages,\n }),\n });\n return { status: r.status, data: await r.json() };\n}\n\nexport default async function (req) {\n const url = new URL(req.url);\n const KEY = Deno.env.get(\"ANTHROPIC_API_KEY\");\n\n if (url.pathname === \"/auth\") {\n if (req.method === \"GET\") {\n return json({\n required: gateOn,\n mode: MODE,\n label: MODE === \"flat\"\n ? \"Enter your flat number to continue.\"\n : \"Enter the resident access code to continue.\",\n placeholder: MODE === \"flat\" ? \"flat-block\" : \"Access code\",\n });\n }\n if (req.method === \"POST\") {\n let code = \"\";\n try {\n const b = await req.json();\n code = String((b && b.code) || \"\");\n } catch (e) {}\n return json({ ok: accepts(code) });\n }\n }\n\n if (req.method === \"POST\" && url.pathname === \"/upload\") {\n let b;\n try {\n b = await req.json();\n } catch (e) {\n return json({ error: \"Bad request.\" }, 400);\n }\n if (gateOn && !accepts(b && b.code)) {\n return json({ error: \"unauthorized\" }, 401);\n }\n if (!b || !b.reference || !b.data) {\n return json({ ok: false, note: \"Missing screenshot data.\" }, 400);\n }\n const res = await postSheet({\n type: \"attachment\",\n reference: b.reference,\n data: b.data,\n mime: b.mime || \"image/png\",\n filename: b.filename || \"screenshot.png\",\n });\n return json(res, res.ok ? 200 : 500);\n }\n\n // Feedback from the injected page widget (no AI call - a direct write, like /upload).\n if (req.method === \"POST\" && url.pathname === \"/feedback\") {\n let b;\n try {\n b = await req.json();\n } catch (e) {\n return json({ error: \"Bad request.\" }, 400);\n }\n if (gateOn && !accepts(b && b.code)) {\n return json({\n ok: false,\n note: \"Please enter your access code in the chat first.\",\n }, 401);\n }\n const kind = String((b && b.kind) || \"\").toLowerCase();\n if ([\"bug\", \"feature_request\", \"praise\", \"criticism\"].indexOf(kind) < 0) {\n return json({ ok: false, note: \"Pick what this is about.\" }, 400);\n }\n let comment = String((b && b.comment) || \"\").trim().slice(0, 2000);\n if (!comment) {\n return json({\n ok: false,\n note: \"Add a line or two so the committee knows what to do.\",\n }, 400);\n }\n // Attach the exchange the resident agreed to share, so a bug can be reproduced.\n const cx = b && b.context;\n if (cx && (cx.question || cx.answer)) {\n comment += \"\\n\\n--- resident's last exchange ---\\nAsked: \" +\n String(cx.question || \"\").slice(0, 800) +\n \"\\nAnswered: \" + String(cx.answer || \"\").slice(0, 1200);\n }\n const st = parseInt(b && b.stars, 10);\n // Derive the flat server-side from the access code, exactly as the chat path does - never trust\n // a client-supplied flat.\n const fbFlat = (MODE === \"flat\" && !(b && b.anonymous))\n ? String((b && b.code) || \"\").trim().toUpperCase()\n : \"\";\n const res = await postSheet({\n type: \"agent_feedback\",\n kind: kind,\n stars: (st >= 1 && st <= 5) ? st : \"\",\n comment: comment,\n flat: fbFlat,\n channel: \"Web\",\n });\n return json(\n res && res.ok\n ? { ok: true }\n : { ok: false, note: \"That did not send. Please try again.\" },\n (res && res.ok) ? 200 : 500,\n );\n }\n\n if (req.method === \"POST\" && url.pathname === \"/api\") {\n if (!KEY) {\n return json({\n error:\n \"The ANTHROPIC_API_KEY environment variable is not set on this val.\",\n }, 500);\n }\n\n let body;\n try {\n body = await req.json();\n } catch (e) {\n return json({ error: \"Bad request.\" }, 400);\n }\n\n // Committee copilot (MC-only, code-gated) — returns a Claude-shaped reply the page already renders.\n if (body && body.mode === \"copilot\") {\n if (!mcAccepts(body.mccode)) return json({ error: \"unauthorized\" }, 401);\n const inc = Array.isArray(body.messages) ? body.messages : [];\n if (!inc.length) return json({ error: \"No message provided.\" }, 400);\n let _sys = null;\n try {\n _sys = await getSystem();\n } catch (e) {}\n const reply = await copilotAnswer(KEY, inc, _sys);\n return json({\n content: [{ type: \"text\", text: reply }],\n stop_reason: \"end_turn\",\n }, 200);\n }\n\n let SYSTEM;\n try {\n SYSTEM = await getSystem();\n } catch (e) {\n return json({\n error:\n \"Bye-law data not linked yet. Set the DATA_URL environment variable to your data val's module URL.\",\n }, 500);\n }\n\n if (gateOn && !accepts(body && body.code)) {\n return json({ error: \"Access code required or incorrect.\" }, 401);\n }\n\n const residentFlat = (MODE === \"flat\")\n ? String((body && body.code) || \"\").trim().toUpperCase()\n : \"\";\n const incoming = Array.isArray(body.messages) ? body.messages : [];\n if (!incoming.length) return json({ error: \"No message provided.\" }, 400);\n\n // Deterministic (no-LLM) complaint-status lookup for clear status intents\n {\n const lastUser = incoming[incoming.length - 1];\n const lastText = (lastUser && lastUser.role !== \"assistant\")\n ? String(lastUser.content || \"\")\n : \"\";\n const cref = complaintRef(lastText);\n if (isComplaintStatus(lastText) && (residentFlat || cref)) {\n let cq = \"q=complaint&flat=\" + encodeURIComponent(residentFlat || \"\");\n if (cref) cq += \"&ref=\" + encodeURIComponent(cref);\n const cd = await sheetGet(cq);\n return json({\n content: [{ type: \"text\", text: formatComplaintsWeb(cd, cref) }],\n }, 200);\n }\n }\n\n const lang = (body && body.lang) || \"en\";\n const langLine = lang === \"hi\"\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 : lang === \"kn\"\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 : \"\";\n\n let messages = incoming.slice(-14).map((m) => ({\n role: m && m.role === \"assistant\" ? \"assistant\" : \"user\",\n content: String((m && m.content) || \"\").slice(0, 4000),\n }));\n\n // Was the resident's latest question about what the committee may or must do? Used below as the\n // deterministic trigger for the verification note.\n let _askedConduct = false;\n for (let i = messages.length - 1; i >= 0; i--) {\n if (messages[i].role === \"user\") {\n _askedConduct = isCommitteeConductQuestion(messages[i].content);\n break;\n }\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 — 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 // These three are independent; running them in series added seconds to every answer.\n // Sequential on purpose. Apps Script serialises concurrent executions of the same script, so\n // firing these together made each one queue behind the others and blow its timeout. One at a\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 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\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 (residentFlat\n ? \"The resident's flat is \" + residentFlat + \".\"\n : \"You do not yet know the resident's flat; if you need it for an action, ask for their flat number and block (A, B, C or D).\") +\n langLine + refLine + statusLine,\n },\n ];\n\n try {\n for (let step = 0; step < 6; step++) {\n const { status, data } = await callClaude(KEY, systemBlocks, messages);\n if (status !== 200) return json(data, status);\n if (data.stop_reason === \"tool_use\") {\n messages.push({ role: \"assistant\", content: data.content });\n const results = [];\n for (const block of data.content) {\n if (block.type === \"tool_use\") {\n const result = await runTool(\n block.name,\n block.input,\n residentFlat,\n );\n results.push({\n type: \"tool_result\",\n tool_use_id: block.id,\n content: JSON.stringify(result),\n });\n }\n }\n messages.push({ role: \"user\", content: results });\n continue;\n }\n if (data && Array.isArray(data.content)) {\n for (const b of data.content) {\n if (b && b.type === \"text\" && typeof b.text === \"string\") {\n b.text = stripCites(b.text);\n // Verdicts, and answers about committee conduct (marked [[VERIFY]]), are what residents\n // screenshot - neither travels without the \"not a ruling\" note.\n const _vf = /\\[\\[VERIFY\\]\\]/i.test(b.text);\n if (_vf) b.text = b.text.replace(/\\[\\[VERIFY\\]\\]/gi, \"\").trim();\n if (\n CONFIG.verifyNote &&\n (_vf || _askedConduct || /^\\s*VERDICT:\\s*\\S/im.test(b.text))\n ) b.text = b.text.trim() + \"\\n\\n\" + CONFIG.verifyNote;\n }\n }\n }\n return json(data, 200);\n }\n return json({\n error: \"The assistant took too many steps. Please try again.\",\n }, 500);\n } catch (e) {\n return json(\n { error: \"Something went wrong reaching the assistant.\" },\n 500,\n );\n }\n }\n\n let _page;\n try {\n _page = await getPage();\n } catch (e) {\n return new Response(\n NAME + \" \\u2014 frontend not linked.\\n\\n\" +\n (e && e.message ? e.message : String(e)),\n { status: 500, headers: { \"content-type\": \"text/plain; charset=utf-8\" } },\n );\n }\n return new Response(_page, {\n headers: { \"content-type\": \"text/html; charset=utf-8\" },\n });\n}\n\n/* ---------- committee-conduct detector ----------\n Deterministic backstop for the verification note: 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 whether\n the model emitted [[VERIFY]]. A safety footer must not depend on model compliance. */\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 json(obj, status) {\n return new Response(JSON.stringify(obj), {\n status: status || 200,\n headers: { \"content-type\": \"application/json\" },\n });\n}","label","askaoaoa",[130],"pulls","branches",1,"forks","envVars",{"_150":152,"_153":61},"connections",{"_150":61,"_151":61},"count","unfilledCount",7,"emptyCount",{"_42":129,"_32":130,"_30":131,"_132":-5,"_40":41,"_39":133,"_134":25,"_37":155,"_13":136,"_33":137,"_35":138,"_24":48,"_139":140,"_156":157,"_27":158},["D",1785946223442],"children",[],[130],["D",1783155855780],["D",1789517443998],{"_97":96,"_105":101},{"_97":96,"_98":99,"_100":101,"_18":55,"_102":103,"_104":48},{"_13":14,"_32":87,"_42":41,"_88":43,"_89":-5,"_90":-5,"_91":-5,"_92":-5,"_93":-5,"_94":44,"_95":96},"ctx",{"_80":-5,"_125":197,"_198":199,"_200":201,"_202":48,"_203":48,"_204":48,"_205":25,"_206":-5,"_207":-7,"_208":-7,"_209":61,"_210":48,"_211":48,"_212":-5,"_213":48,"_214":48,"_215":48,"_216":-5},"ENV",{"_168":169,"_170":171,"_172":87,"_173":174,"_175":176,"_177":178,"_179":180,"_181":182,"_183":184,"_185":186,"_187":188,"_189":190,"_191":192,"_193":194,"_195":196},"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 · v107