You don't have access to this dashboard.

\n Ask the owner to add your Val Town username to the{\" \"}\n ADMIN_USERNAMES environment variable.\n

\n \n

\n ,\n 403,\n );\n }\n c.set(\"user\", result);\n await next();\n});\n\nadmin.get(\"/\", c => renderDashboard(c));\n\n/* ---------------------------------- receivers ---------------------------------- */\n\nadmin.post(\"/receivers\", async (c) => {\n const body = await c.req.parseBody({ all: true });\n const input = receiverFromBody(body);\n if (!input.topic) return back(\"err\", \"A topic is required\");\n await db.createReceiver({ ...input, auth: str(body.auth).trim() || null });\n return back(\"ok\", `Receiver “${input.name}” added`);\n});\n\nadmin.post(\"/receivers/:id\", async (c) => {\n const id = c.req.param(\"id\");\n const body = await c.req.parseBody({ all: true });\n const action = str(body._action);\n\n const receiver = await db.getReceiver(id);\n if (!receiver) return back(\"err\", \"Receiver not found\");\n\n if (action === \"delete\") {\n await db.deleteReceiver(id);\n return back(\"ok\", `Receiver “${receiver.name}” deleted`);\n }\n\n if (action === \"test\") {\n const result = await sendTest(receiver, new URL(c.req.url).origin);\n return result.ok\n ? back(\"ok\", `Test sent to ${receiver.server}/${receiver.topic} (filters bypassed)`)\n : back(\"err\", `Test failed (${result.status ?? \"network\"}): ${result.error ?? \"unknown error\"}`);\n }\n\n const input = receiverFromBody(body);\n if (!input.topic) return back(\"err\", \"A topic is required\");\n\n // Auth: blank input keeps the stored secret, \"clear_auth\" removes it.\n const newAuth = str(body.auth).trim();\n const auth = body.clear_auth ? null : newAuth ? newAuth : undefined;\n\n await db.updateReceiver(id, { ...input, ...(auth === undefined ? {} : { auth }) });\n return back(\"ok\", `Receiver “${input.name}” saved`);\n});\n\n/* -------------------------------- filter tester -------------------------------- */\n\nadmin.post(\"/filter-test\", async (c) => {\n const body = await c.req.parseBody();\n const email = str(body.email).trim() || \"someone@example.com\";\n const detailsText = str(body.details);\n\n let details: Record | null = null;\n let parseError: string | undefined;\n const trimmed = detailsText.trim();\n if (trimmed) {\n try {\n const parsed = JSON.parse(trimmed);\n if (parsed === null || typeof parsed !== \"object\" || Array.isArray(parsed)) {\n parseError = \"expected a JSON object, e.g. {\\\"plan\\\": \\\"enterprise\\\"}\";\n } else {\n details = parsed as Record;\n }\n } catch (err: any) {\n parseError = err?.message ?? String(err);\n }\n }\n\n if (parseError) {\n return renderDashboard(c, { email, detailsText, parseError, rows: [] });\n }\n\n const receivers = await db.listReceivers();\n const sample: db.Subscriber = {\n id: 0,\n email,\n details,\n developer_notes: null,\n created_at: \"(dry run)\",\n updated_at: \"(dry run)\",\n };\n\n const rows = receivers.map((receiver) => {\n const decision = decideForReceiver(receiver, sample);\n return {\n receiver: receiver.name,\n enabled: !!receiver.enabled,\n events: receiver.events,\n listens: receiver.events.split(\",\").map(e => e.trim()).includes(\"signup\"),\n send: decision.send,\n outcome: decision.outcome,\n reason: decision.reason,\n };\n });\n\n return renderDashboard(c, { email, detailsText, rows });\n});\n\n/* --------------------------------- subscribers --------------------------------- */\n\nadmin.post(\"/subscribers/:id\", async (c) => {\n const id = c.req.param(\"id\");\n const body = await c.req.parseBody();\n const action = str(body._action);\n\n if (action === \"delete\") {\n await db.deleteSubscriber(id);\n return back(\"ok\", `Signup #${id} deleted`);\n }\n\n await db.updateSubscriber(id, { developer_notes: str(body.developer_notes) });\n return back(\"ok\", `Notes saved for #${id}`);\n});\n",[],[267,259],"admin","6eb89ce3-a586-46a0-aa2d-100ac5a04ae3","Subscribers.tsx","fbee90e4-9af8-11f1-96e3-1607ee4eb77e",22,["D",1787052959417],"/** @jsxImportSource https://esm.sh/react@18.2.0 */\nimport React from \"https://esm.sh/react@18.2.0\";\nimport type { Subscriber } from \"../db.ts\";\nimport { Card } from \"./Layout.tsx\";\n\nfunction DetailsCell({ details }: { details: Record | null }) {\n if (!details || !Object.keys(details).length) {\n return —;\n }\n return (\n

\n {Object.keys(details).length} field{Object.keys(details).length === 1 ? \"\" : \"s\"}\n

\n        {JSON.stringify(details, null, 2)}\n

\n );\n}\n\nexport function Subscribers(\n { subscribers, total }: { subscribers: Subscriber[]; total: number },\n) {\n return (\n \n {subscribers.length === 0\n ?

No signups yet.

\n : (\n

\n \n \n \n \n \n \n \n \n \n \n \n \n {subscribers.map((s) => (\n \n \n \n \n \n \n \n \n ))}\n \n

#	Email	Details	Created (UTC)	Notes
{s.id}	{s.email}	\n \n	{s.created_at}	\n \n \n \n Save\n \n \n	\n \n \n Delete\n \n \n

\n )}\n \n );\n}\n",[],[267,269],"49020ae2-44f1-4431-9987-243a6867b588","Receivers.tsx","f55367e6-9af8-11f1-9164-1607ee4eb77e",44,["D",1787056244788],"/** @jsxImportSource https://esm.sh/react@18.2.0 */\nimport React from \"https://esm.sh/react@18.2.0\";\nimport type { Delivery, Receiver } from \"../db.ts\";\nimport { parseFilter, summarizeFilter } from \"../filter.ts\";\nimport { Card } from \"./Layout.tsx\";\n\nconst PRIORITIES = [\n [1, \"1 · min\"],\n [2, \"2 · low\"],\n [3, \"3 · default\"],\n [4, \"4 · high\"],\n [5, \"5 · max\"],\n] as const;\n\nconst input =\n \"w-full px-2.5 py-1.5 rounded-md border border-slate-300 text-sm focus:outline-none focus:ring-2 focus:ring-slate-400\";\nconst label = \"block text-xs font-medium text-slate-500 mb-1\";\n\nfunction Field(\n { name, title, defaultValue, placeholder, type = \"text\", hint, required, className = \"\" }: {\n name: string;\n title: string;\n defaultValue?: string | number | null;\n placeholder?: string;\n type?: string;\n hint?: string;\n required?: boolean;\n className?: string;\n },\n) {\n return (\n

\n {title}\n \n {hint &&

{hint}

}\n

\n );\n}\n\nfunction EventChecks({ events }: { events: string }) {\n const list = events.split(\",\").map(e => e.trim());\n return (\n

\n Notify on\n

\n \n \n New signup\n \n \n \n Details updated\n \n

\n );\n}\n\nexport function FilterSyntax() {\n return (\n

Filter syntax

\n One rule per line. Fields come from the signup's details object, plus{\" \"}\n email. Nested paths work: utm.source, answers[0].value.\n

\n{`plan = enterprise      # equals (case-insensitive)\nplan != trial          # not equals\ncompany exists         # provided and not empty\nphone missing          # absent, null or empty\ncountry in US, CA, MX  # any of\nemail ~ @acme.com      # contains\nseats >= 10            # numeric: > >= < <=\n# lines starting with # are comments`}\n

Array values match if any element matches.
\n != is also true when the field is absent — add field exists{\" \"}\n if you need it present.\n
false and 0 count as present; \"\" and [] don't.
A filter that can't be parsed sends anyway, so a typo never silently drops alerts.

\n );\n}\n\nfunction FilterBox({ receiver }: { receiver?: Receiver }) {\n const parsed = parseFilter(receiver?.filter ?? null);\n return (\n

\n Filter (optional)\n \n \n \n \n

\n \n {parsed.errors.length > 0\n ? (\n

\n line {err.line} {err.source} — {err.message} (sending everything\n until fixed)\n

\n )\n : (\n

\n {summarizeFilter(receiver?.filter ?? null, receiver?.filter_mode ?? \"all\")}\n

\n )}\n

\n );\n}\n\nfunction ReceiverFields({ receiver }: { receiver?: Receiver }) {\n return (\n <>\n

\n \n \n \n

\n Priority\n \n

\n \n \n

\n \n

\n \n \n Enabled\n \n {receiver?.auth && (\n \n \n Clear saved auth\n \n )}\n

\n \n );\n}\n\nconst DOT_COLORS: Record = {\n sent: \"bg-emerald-500\",\n failed: \"bg-red-500\",\n skipped: \"bg-amber-400\",\n};\n\nfunction StatusDot({ outcome }: { outcome?: string }) {\n return (\n \n );\n}\n\nfunction lastLine(last?: Delivery): string {\n if (!last) return \"no deliveries yet\";\n if (last.outcome === \"sent\") return `last ${last.event} sent · ${last.created_at}`;\n if (last.outcome === \"skipped\") return `last ${last.event} filtered out · ${last.created_at}`;\n return `last ${last.event} failed (${last.status ?? \"network\"}) · ${last.created_at}`;\n}\n\nexport function Receivers(\n { receivers, deliveries }: { receivers: Receiver[]; deliveries: Delivery[] },\n) {\n const lastByReceiver = new Map();\n for (const d of deliveries) {\n if (d.receiver_id !== null && !lastByReceiver.has(d.receiver_id)) lastByReceiver.set(d.receiver_id, d);\n }\n\n return (\n \n \n\n {receivers.length === 0 && (\n

\n No receivers yet — add one below, then subscribe to that topic in the{\" \"}\n ntfy web app or mobile app.\n

\n )}\n\n

\n {receivers.map((receiver) => {\n const last = lastByReceiver.get(receiver.id);\n return (\n \n

\n \n {receiver.name}\n \n {receiver.server.replace(/^https?:\\/\\//, \"\")}/{receiver.topic}\n \n {!receiver.enabled && (\n \n disabled\n \n )}\n

{lastLine(last)}

\n\n \n\n

\n \n Save\n \n \n Send test\n \n \n Delete\n \n

\n \n );\n })}\n

\n\n

\n + Add receiver\n

\n \n );\n}\n\nconst OUTCOME_STYLES: Record = {\n sent: \"text-emerald-600\",\n failed: \"text-red-600\",\n skipped: \"text-amber-600\",\n};\n\nexport function Deliveries({ deliveries }: { deliveries: Delivery[] }) {\n if (!deliveries.length) return null;\n return (\n \n

\n \n \n \n \n \n \n \n \n \n \n \n {deliveries.map((d) => (\n \n \n \n \n \n \n \n ))}\n \n

When (UTC)	Receiver	Event	Signup	Result
{d.created_at}	{d.receiver_name}	{d.event}	\n {d.subscriber_id ? `#${d.subscriber_id}` : \"—\"}\n	\n \n {d.outcome === \"failed\" ? `failed ${d.status ?? \"network\"}` : d.outcome}\n \n {d.error && · {d.error}}\n

\n \n );\n}\n",[],[267,277],"246d6b1f-bdb2-46dc-aaa0-dfcdeb912df0","Layout.tsx","dd81d7ce-9af8-11f1-8710-1607ee4eb77e",20,["D",1787052908390],"/** @jsxImportSource https://esm.sh/react@18.2.0 */\nimport React from \"https://esm.sh/react@18.2.0\";\n\nexport interface FlashMessage {\n kind: \"ok\" | \"error\";\n text: string;\n}\n\nexport function Layout(\n { title, user, flash, children }: {\n title: string;\n user: { username: string | null; profileImageUrl?: string | null };\n flash?: FlashMessage | null;\n children: React.ReactNode;\n },\n) {\n return (\n \n \n \n \n {title}\n \n \n \n \n

📬 Newsletter Signups

\n Review submissions and configure ntfy.sh receivers\n

\n @{user.username ?? \"unknown\"}\n

\n\n {flash && (\n \n {flash.text}\n

\n )}\n\n {children}\n\n \n \n \n \n );\n}\n\nexport function Card(\n { title, subtitle, children }: {\n title: string;\n subtitle?: string;\n children: React.ReactNode;\n },\n) {\n return (\n

{title}

\n {subtitle &&

{subtitle}

}\n

{children}

\n );\n}\n",[],[267,285],"ec3aacd5-82f2-4a7b-ae01-b738fc43968d","FilterTest.tsx","b426c8fa-9b00-11f1-8b2d-1607ee4eb77e",45,["D",1787056274986],"/** @jsxImportSource https://esm.sh/react@18.2.0 */\nimport React from \"https://esm.sh/react@18.2.0\";\nimport { Card } from \"./Layout.tsx\";\n\nexport interface FilterTestRow {\n receiver: string;\n enabled: boolean;\n events: string;\n listens: boolean;\n send: boolean;\n outcome: string;\n reason: string;\n}\n\nexport interface FilterTestResult {\n email: string;\n detailsText: string;\n parseError?: string;\n rows: FilterTestRow[];\n}\n\nconst input =\n \"w-full px-2.5 py-1.5 rounded-md border border-slate-300 text-sm focus:outline-none focus:ring-2 focus:ring-slate-400\";\n\nfunction Verdict({ row }: { row: FilterTestRow }) {\n if (!row.enabled) return receiver disabled;\n if (!row.listens) return not listening for signups;\n if (row.outcome === \"error\") return would send (filter error);\n return row.send\n ? would send\n : would skip;\n}\n\n/**\n * \"What would happen if this signup arrived?\" — filters are invisible by nature, so this\n * makes them inspectable without publishing real notifications.\n */\nexport function FilterTest(\n { result, defaults }: {\n result?: FilterTestResult;\n defaults: { email: string; detailsText: string };\n },\n) {\n return (\n \n \n\n {result?.parseError && (\n

\n Couldn't parse that JSON: {result.parseError}\n

\n )}\n\n {result && !result.parseError && (\n result.rows.length === 0\n ?

No receivers configured yet.

\n : (\n

\n \n \n \n \n \n \n \n \n \n {result.rows.map((row) => (\n \n \n \n \n \n ))}\n \n

Receiver	Verdict	Why
{row.receiver}	\n \n	{row.reason}

\n )\n )}\n \n );\n}\n",[],[267,293],"964d6db5-0871-412c-97ed-cb80b4512abb",["D",1787052908390],[182,183,184,185,186],[267],["D",1769884195507],["D",1789534231467],{"_11":12,"_138":71},{"_11":12,"_134":-5,"_70":71,"_30":69,"_135":136,"_137":24},{"_40":125,"_13":16,"_34":37,"_126":88,"_127":-5,"_128":-5,"_129":-5,"_130":-5,"_131":-5,"_132":14,"_133":12},"ctx",{"_54":-5,"_158":342,"_343":344,"_345":346,"_347":24,"_348":24,"_349":24,"_350":156,"_351":-5,"_352":-7,"_353":-7,"_354":26,"_355":24,"_356":24,"_357":-5,"_358":24,"_359":24,"_360":24,"_361":-5},"ENV",{"_313":314,"_315":316,"_317":16,"_318":319,"_320":321,"_322":323,"_324":325,"_326":327,"_328":329,"_330":331,"_332":333,"_334":335,"_336":337,"_338":339,"_340":341},"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"]

History · filter.ts