${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}",[132],"pulls",1,"forks","envVars",{"_145":147,"_148":54},"connections",{"_145":54,"_146":54},"count","unfilledCount",7,"emptyCount",{"_20":131,"_13":132,"_117":48,"_119":-5,"_120":21,"_121":30,"_123":50,"_22":155,"_29":134,"_125":135,"_127":136,"_128":38,"_129":-5,"_152":156,"_91":157},{"_20":115,"_13":116,"_117":118,"_119":-5,"_120":21,"_121":122,"_123":50,"_22":151,"_29":54,"_125":126,"_127":43,"_128":38,"_129":-5,"_152":153,"_91":154},["D",1785860260789],"children",[],[116],["D",1786860958818],[],[132],["D",1785310391283],{"_11":12,"_89":85},{"_11":12,"_82":83,"_84":85,"_45":46,"_86":87,"_88":38},{"_29":30,"_13":26,"_20":21,"_27":28,"_31":-5,"_32":-5,"_77":-5,"_78":-5,"_79":-5,"_80":14,"_81":12},"ctx",{"_70":-5,"_110":195,"_196":197,"_198":199,"_200":38,"_201":38,"_202":38,"_203":50,"_204":-5,"_205":-7,"_206":-7,"_207":54,"_208":38,"_209":38,"_210":-5,"_211":38,"_212":38,"_213":38,"_214":-5},"ENV",{"_166":167,"_168":169,"_170":26,"_171":172,"_173":174,"_175":176,"_177":178,"_179":180,"_181":182,"_183":184,"_185":186,"_187":188,"_189":190,"_191":192,"_193":194},"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"]

Branches1

Branches
1