${title}

${body}

\n`;\n\nconst accessBody = `

🔒

SOC FM Dashboard

Enter the access code to view.

\n`;\n\nconst emptyBody = `

💤

No snapshot yet

Turn on your laptop (or wait for the next sync) and this page will fill in. It refreshes automatically.

`;\n\nexport default async function (req: Request): Promise {\n const url = new URL(req.url);\n\n // ---- 1. Telegram webhook (cloud answers when the laptop is off) ----\n const tgHdr = req.headers.get(\"x-telegram-bot-api-secret-token\");\n if (req.method === \"POST\" && tgHdr !== null) {\n if (!TG_SECRET || tgHdr !== TG_SECRET) return new Response(\"no\", { status: 401 });\n // Always return 200 so Telegram doesn't retry; do the work best-effort.\n try {\n const update: any = await req.json().catch(() => ({}));\n const msg = update.message;\n if (msg && msg.text && msg.chat) {\n const fromId = String(msg.from?.id ?? \"\");\n const chatId = msg.chat.id;\n if (!ALLOWED.includes(fromId)) {\n await tgSend(chatId, \"Sorry, you are not authorised to use this bot.\");\n return new Response(\"ok\");\n }\n const snap = await readSnapshot();\n const stamp = snap?.generatedAt ? String(snap.generatedAt).slice(0, 16).replace(\"T\", \" \") : \"?\";\n const suffix = `\\n\\n🕓 as of ${stamp} · laptop offline`;\n const cmd = classify(msg.text);\n const textTrim = (msg.text || \"\").trim();\n\n if (/^cancel$/i.test(textTrim)) {\n // Remove this chat's most-recently queued pending change.\n const q = await readQueue();\n let idx = -1;\n for (let i = q.length - 1; i >= 0; i--) { if (String(q[i].chatId) === String(chatId)) { idx = i; break; } }\n if (idx === -1) { await tgSend(chatId, \"Nothing queued to cancel.\"); }\n else { const removed = q.splice(idx, 1)[0]; await writeQueue(q); await tgSend(chatId, `Removed from the queue:\\n\"${removed.text}\"`); }\n } else if (!snap) {\n await tgSend(chatId, \"The laptop hasn't pushed a snapshot yet — turn it on once so I have data to answer from.\");\n } else if (cmd && [\"dashboard\", \"overdue\", \"aircon\", \"claims\", \"nc\"].includes(cmd)) {\n await tgSend(chatId, (snap.commands?.[cmd] ?? \"(not available in the snapshot)\") + suffix);\n } else if (cmd === \"help\" || cmd === \"start\") {\n await tgSend(chatId, (snap.commands?.help ?? \"BotFMTracker (cloud).\") + suffix);\n } else if (cmd === \"menu\") {\n await tgSend(chatId, \"Menu (laptop offline): /dashboard /overdue /aircon /claims /nc /help\\nStatus changes get queued for the laptop; drafts & Excel reports need the laptop online.\");\n } else if (cmd === \"draft\" || cmd === \"report\") {\n await tgSend(chatId, \"That needs the laptop online (it uses Outlook / Excel). I'll be able to do it once the laptop is back on.\");\n } else if (looksLikeStatusChange(msg.text)) {\n // Hold a WR status change; the laptop applies it (with a backup) when next on.\n const q = await readQueue();\n if (q.length >= 20) {\n await tgSend(chatId, \"⚠️ Your pending list is full (20 changes). Turn the laptop on to apply them first.\");\n } else {\n q.push({ id: crypto.randomUUID(), chatId, userId: fromId, text: textTrim, createdAt: new Date().toISOString(), state: \"pending\" });\n await writeQueue(q);\n await tgSend(chatId, `📥 Queued for your laptop — I'll apply it the moment the laptop is next on:\\n\"${textTrim}\"\\n\\nReply CANCEL to remove the last one.` + suffix);\n }\n } else if (!ANTHROPIC_KEY) {\n await tgSend(chatId, \"Free-text answers aren't enabled in the cloud. Tap a button (/dashboard, /overdue…) or ask again when the laptop's on.\");\n } else {\n await tgSend(chatId, (await askClaude(snap.digest ?? \"\", msg.text)) + suffix);\n }\n }\n } catch { /* swallow - Telegram just needs a 200 */ }\n return new Response(\"ok\");\n }\n\n // ---- 2. Publish (laptop -> cloud) ----\n if (req.method === \"POST\") {\n if (!PUBLISH_TOKEN || req.headers.get(\"x-publish-token\") !== PUBLISH_TOKEN) {\n return new Response(\"unauthorized\", { status: 401 });\n }\n const body = await req.text();\n if (url.searchParams.get(\"kind\") === \"snapshot\") {\n if (!body || body.length < 2) return new Response(\"empty body\", { status: 400 });\n await blob.set(SNAP_KEY, body);\n return new Response(\"ok (snapshot)\");\n }\n if (url.searchParams.get(\"kind\") === \"queue-clear\") {\n // The laptop has applied these queued changes -> drop them.\n let ids: string[] = [];\n try { ids = (JSON.parse(body || \"{}\").ids) ?? []; } catch { ids = []; }\n const idset = new Set(ids.map(String));\n const q = (await readQueue()).filter((it) => !idset.has(String(it.id)));\n await writeQueue(q);\n return new Response(\"ok (queue-clear)\");\n }\n if (!body || body.length < 50) return new Response(\"empty body\", { status: 400 });\n await blob.set(HTML_KEY, body);\n return new Response(\"ok\");\n }\n\n // ---- 2b. Queue pull (laptop -> cloud, token-gated) ----\n if (url.searchParams.get(\"kind\") === \"queue\") {\n if (!PUBLISH_TOKEN || req.headers.get(\"x-publish-token\") !== PUBLISH_TOKEN) {\n return new Response(\"unauthorized\", { status: 401 });\n }\n return new Response(JSON.stringify(await readQueue()), {\n headers: { \"content-type\": \"application/json\" },\n });\n }\n\n // ---- 3. Dashboard view (phone -> cloud) ----\n const secret = url.searchParams.get(\"secret\") ?? \"\";\n if (!VIEW_SECRET || secret !== VIEW_SECRET) {\n return new Response(page(\"SOC FM Dashboard - access\", accessBody), {\n status: 401, headers: { \"content-type\": \"text/html; charset=utf-8\" },\n });\n }\n let html: string | null = null;\n try { html = await (await blob.get(HTML_KEY)).text(); } catch { html = null; }\n if (!html) {\n return new Response(page(\"SOC FM Dashboard\", emptyBody, 20), {\n headers: { \"content-type\": \"text/html; charset=utf-8\" },\n });\n }\n return new Response(html, { headers: { \"content-type\": \"text/html; charset=utf-8\" } });\n}",[57],{"_34":56,"_13":57,"_37":58,"_39":-5,"_40":41,"_42":59,"_44":45,"_46":71,"_17":61,"_49":62,"_51":63,"_52":53,"_54":-5,"_68":72,"_18":73},{"_34":35,"_13":36,"_37":38,"_39":-5,"_40":41,"_42":43,"_44":45,"_46":67,"_17":48,"_49":50,"_51":19,"_52":53,"_54":-5,"_68":69,"_18":70},["D",1785860260789],"children",[],[36],["D",1786860958818],[],[57],"270e9d38-077b-495b-9725-45e250b45f92",["D",1785310391283],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","imageUrl","userId","ab50d419-4c1c-4363-b7b2-0981fd386517","pinnedFileId","pinPreview","pinMigrated","screenshotVersion","likeCount","orgId","019faca7-3dea-741a-9d4f-ff092811e72d","tursoName","tursoHostname","tursoMeasuredAt","pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_11":12,"_127":123},"org",{"_11":12,"_120":121,"_122":123,"_83":84,"_124":125,"_126":53},"branch",{"_17":59,"_13":16,"_34":41,"_112":74,"_113":-5,"_114":-5,"_115":-5,"_116":-5,"_117":-5,"_118":14,"_119":12},"isOwned","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","displayName","TheMiintz","avatar","https://avatars.githubusercontent.com/u/280869999?v=4","tier","free","canRestrictVals","profileImageUrl","adoptOrgId",{"_34":74,"_13":14,"_46":167,"_76":-5,"_77":53,"_78":79,"_80":79,"_81":19,"_82":-5,"_83":84,"_85":58,"_86":45,"_87":-5,"_88":-5,"_89":48,"_90":91,"_92":-5,"_93":-5,"_94":-5,"_95":-5,"_96":97,"_98":97,"_99":100,"_101":100,"_102":100,"_103":97,"_104":97,"_105":168,"_107":169,"_109":170,"_111":53},[161,162],"files",[161,162],"counts",{"_150":48,"_151":152,"_153":48,"_31":154,"_155":156},[146,147],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},{"_34":56,"_13":57,"_37":58,"_39":-5,"_40":41,"_42":59,"_44":45,"_46":60,"_17":61,"_49":62,"_51":63,"_52":53,"_54":-5,"_18":149},{"_34":35,"_13":36,"_37":38,"_39":-5,"_40":41,"_42":43,"_44":45,"_46":47,"_17":48,"_49":50,"_51":19,"_52":53,"_54":-5,"_18":148},[36],[57],"pulls","branches",1,"forks",{"_157":159,"_160":48},"connections",{"_157":48,"_158":48},"count","unfilledCount",7,"emptyCount",{"_34":56,"_13":57,"_37":58,"_39":-5,"_40":41,"_42":59,"_44":45,"_46":71,"_17":61,"_49":62,"_51":63,"_52":53,"_54":-5,"_68":165,"_18":166},{"_34":35,"_13":36,"_37":38,"_39":-5,"_40":41,"_42":43,"_44":45,"_46":67,"_17":48,"_49":50,"_51":19,"_52":53,"_54":-5,"_68":163,"_18":164},[],[36],[],[57],["D",1785310391283],{"_11":12,"_127":123},{"_11":12,"_120":121,"_122":123,"_83":84,"_124":125,"_126":53},{"_17":59,"_13":16,"_34":41,"_112":74,"_113":-5,"_114":-5,"_115":-5,"_116":-5,"_117":-5,"_118":14,"_119":12},"ctx",{"_105":-5,"_143":204,"_205":206,"_207":208,"_209":53,"_210":53,"_211":53,"_212":45,"_213":-5,"_214":-7,"_215":-7,"_216":48,"_217":53,"_218":53,"_219":-5,"_220":53,"_221":53,"_222":53,"_223":-5},"ENV",{"_175":176,"_177":178,"_179":16,"_180":181,"_182":183,"_184":185,"_186":187,"_188":189,"_190":191,"_192":193,"_194":195,"_196":197,"_198":199,"_200":201,"_202":203},"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"]

Code