[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_199":200,"_201":202},"routes/_app.x.$handle.$name",{"_102":101,"_37":49,"_110":92,"_32":111,"_13":14,"_112":-5,"_11":113,"_114":115,"_116":117,"_118":119,"_120":121,"_26":-5,"_122":-5,"_123":-5,"_124":30,"_125":126,"_127":128,"_129":-5,"_130":-5,"_131":132},"routes/_app.x.$handle.$name.branch.$branch.version.$version.diff",{"_11":12,"_13":14,"_15":16,"_17":18,"_19":-5},"project",{"_47":48,"_37":49,"_42":50,"_51":-5,"_52":30,"_53":54,"_55":54,"_56":57,"_58":-5,"_19":59,"_60":-5,"_61":30,"_62":-5,"_63":-5,"_64":65,"_66":67,"_68":69,"_70":71,"_72":73,"_74":-5,"_75":76,"_77":76,"_78":79,"_80":79,"_81":79,"_82":76,"_83":76,"_84":85,"_86":87,"_88":89,"_90":30},"version",18,"changes",[25],"aiChatInfo",{"_20":21,"_22":-5,"_23":-5,"_24":-5},"userId","aiChatMessageId","f3e53391-110a-4420-b972-27b749c4c5c1","aiChatThreadId","aiChatThreadUserId","aiChatThreadTitle",{"_26":27,"_28":-7,"_29":30,"_31":30,"_32":33,"_34":33},"file",{"_35":36,"_37":33,"_38":39,"_40":41,"_42":43,"_44":14,"_45":46,"_29":30},"previous","deleted",false,"deletedHere","path","ntfy.ts","latestPath","fileId","c9b89cf0-9af8-11f1-9164-1607ee4eb77e","name","fileType","script","content","/**\n * ntfy.sh publishing.\n *\n * Uses ntfy's \"publish as JSON\" API: POST the message object (including `topic`)\n * to the server ROOT url — not the topic url.\n * https://docs.ntfy.sh/publish/#publish-as-json\n *\n * Auth (https://docs.ntfy.sh/publish/#authentication):\n * - access token -> Authorization: Bearer tk_…\n * - user:password -> Authorization: Basic base64(user:password)\n */\n\nimport {\n logDelivery,\n type NtfyEvent,\n type Receiver,\n receiversForEvent,\n type Subscriber,\n} from \"./db.ts\";\n\nexport interface NtfyMessage {\n topic: string;\n message: string;\n title?: string;\n tags?: string[];\n priority?: number;\n click?: string;\n markdown?: boolean;\n actions?: Array<{ action: string; label: string; url?: string; clear?: boolean }>;\n}\n\nexport interface PublishResult {\n ok: boolean;\n status: number | null;\n error: string | null;\n}\n\nfunction authHeader(auth: string | null): Record {\n const value = auth?.trim();\n if (!value) return {};\n // Access tokens are prefixed tk_; anything with a colon is user:password.\n if (value.startsWith(\"tk_\") || !value.includes(\":\")) {\n return { Authorization: `Bearer ${value}` };\n }\n return { Authorization: `Basic ${btoa(value)}` };\n}\n\nexport function normalizeServer(server: string): string {\n const trimmed = (server || \"https://ntfy.sh\").trim().replace(/\\/+$/, \"\");\n return /^https?:\\/\\//.test(trimmed) ? trimmed : `https://${trimmed}`;\n}\n\n/** Publish a single message to one receiver's server + topic. */\nexport async function publish(\n receiver: Pick,\n message: Omit & { tags?: string[] },\n): Promise {\n const body: NtfyMessage = {\n topic: receiver.topic.trim(),\n priority: receiver.priority,\n tags: message.tags ?? receiver.tags?.split(\",\").map(t => t.trim()).filter(Boolean),\n ...message,\n };\n\n try {\n const res = await fetch(normalizeServer(receiver.server) + \"/\", {\n method: \"POST\",\n headers: { \"Content-Type\": \"application/json\", ...authHeader(receiver.auth) },\n body: JSON.stringify(body),\n signal: AbortSignal.timeout(10_000),\n });\n if (!res.ok) {\n const text = (await res.text().catch(() => \"\")).slice(0, 300);\n return { ok: false, status: res.status, error: text || res.statusText };\n }\n await res.body?.cancel();\n return { ok: true, status: res.status, error: null };\n } catch (err: any) {\n return { ok: false, status: null, error: err?.message ?? String(err) };\n }\n}\n\nfunction formatDetails(details: Record | null): string {\n if (!details || !Object.keys(details).length) return \"\";\n return Object.entries(details)\n .map(([k, v]) => `- **${k}:** ${typeof v === \"object\" ? JSON.stringify(v) : String(v)}`)\n .join(\"\\n\");\n}\n\nfunction buildMessage(event: NtfyEvent, subscriber: Subscriber, adminUrl?: string) {\n const detailLines = formatDetails(subscriber.details);\n const title = event === \"signup\"\n ? \"New newsletter signup\"\n : `Signup details updated (#${subscriber.id})`;\n const lines = [\n subscriber.email,\n detailLines,\n `_#${subscriber.id} · ${subscriber.created_at} UTC_`,\n ].filter(Boolean);\n return {\n title,\n message: lines.join(\"\\n\"),\n markdown: true,\n click: adminUrl,\n actions: adminUrl\n ? [{ action: \"view\", label: \"Open admin\", url: adminUrl, clear: false }]\n : undefined,\n };\n}\n\n/**\n * Fan a signup event out to every enabled receiver listening for it.\n * Never throws — failures are logged to ntfy_deliveries so the admin page can show them.\n */\nexport async function notify(\n event: NtfyEvent,\n subscriber: Subscriber,\n origin?: string,\n): Promise {\n const receivers = await receiversForEvent(event).catch(() => []);\n if (!receivers.length) return [];\n\n const adminUrl = origin ? `${origin.replace(/\\/+$/, \"\")}/admin` : undefined;\n const payload = buildMessage(event, subscriber, adminUrl);\n\n const results = await Promise.all(receivers.map(async (receiver) => {\n const result = await publish(receiver, payload);\n if (!result.ok) {\n console.error(`ntfy: ${receiver.name} (${receiver.topic}) failed:`, result.status, result.error);\n }\n await logDelivery({\n receiver_id: receiver.id,\n receiver_name: receiver.name,\n subscriber_id: subscriber.id,\n event,\n ok: result.ok,\n status: result.status,\n error: result.error,\n }).catch(() => {});\n return result;\n }));\n\n return results;\n}\n\n/** Send a \"does this config work?\" message to one receiver. */\nexport async function sendTest(receiver: Receiver, origin?: string): Promise {\n const adminUrl = origin ? `${origin.replace(/\\/+$/, \"\")}/admin` : undefined;\n const result = await publish(receiver, {\n title: \"Newsletter signup test\",\n message: `Test notification for receiver **${receiver.name}**. If you can read this, alerts work. 🎉`,\n markdown: true,\n click: adminUrl,\n });\n await logDelivery({\n receiver_id: receiver.id,\n receiver_name: receiver.name,\n subscriber_id: null,\n event: \"test\",\n ok: result.ok,\n status: result.status,\n error: result.error,\n }).catch(() => {});\n return result;\n}\n","createdAt",["D",1787052875199],"branchVersion","branchId","d72d2544-fed2-11f0-a1dd-42dde27851f2","id","d72cb6b8-fed2-11f0-a1dd-42dde27851f2","newsletter-signup",["D",1769884195507],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","Signup API with ntfy push alerts and an admin dashboard","imageUrl","c821e8f7-4cc4-4c23-96f1-319b8f33d4b7","pinnedFileId","pinPreview","pinMigrated","screenshotVersion","likeCount",0,"orgId","6b193d60-e165-45a9-869c-c3f886455f3e","tursoName","d72cb6b8fed211f0a1dd42dde27851f2","tursoHostname","d72cb6b8fed211f0a1dd42dde27851f2-val-town.aws-us-east-2.turso.io","tursoMeasuredAt",["D",1789534231467],"pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_102":101,"_109":105},"org",{"_102":101,"_103":-5,"_104":105,"_19":59,"_106":107,"_108":30},"branch",{"_13":91,"_37":92,"_47":46,"_93":48,"_94":-5,"_95":-5,"_96":-5,"_97":-5,"_98":-5,"_99":49,"_100":101},"isOwned",51,"main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","colel","handle","displayName","avatar","https://img.clerk.com/eyJ0eXBlIjoicHJveHkiLCJzcmMiOiJodHRwczovL2ltYWdlcy5jbGVyay5kZXYvdXBsb2FkZWQvaW1nXzJ6RVZCOExVNXBIT3FrVDh5a0VZQTNRRG5ycCJ9","tier","pro","canRestrictVals","profileImageUrl","branchName","","adoptOrgId",{"_47":48,"_37":49,"_42":194,"_51":-5,"_52":30,"_53":54,"_55":54,"_56":57,"_58":-5,"_19":59,"_60":-5,"_61":30,"_62":-5,"_63":-5,"_64":65,"_66":67,"_68":69,"_70":71,"_72":195,"_74":-5,"_75":76,"_77":76,"_78":79,"_80":79,"_81":79,"_82":76,"_83":76,"_84":196,"_86":197,"_88":198,"_90":30},"tree",[177,178,179,180],"files",[177,178,179,180],"counts",{"_166":65,"_167":168,"_169":65,"_170":171,"_172":173},"contents",[133,134,135,136],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles",true,"grants","orgs","customDomains",{},{"_47":159,"_37":160,"_35":161,"_138":-5,"_45":46,"_44":162,"_139":30,"_42":163,"_13":65,"_38":26,"_40":164,"_29":30,"_141":-5,"_32":165},{"_47":152,"_37":153,"_35":154,"_138":-5,"_45":46,"_44":155,"_139":30,"_42":156,"_13":65,"_38":39,"_40":157,"_29":30,"_141":-5,"_32":158},{"_47":143,"_37":144,"_35":145,"_138":-5,"_45":46,"_44":146,"_139":30,"_42":147,"_13":148,"_38":149,"_40":150,"_29":30,"_141":49,"_32":151},{"_47":137,"_37":33,"_35":36,"_138":-5,"_45":46,"_44":14,"_139":30,"_42":140,"_13":65,"_38":39,"_40":41,"_29":30,"_141":-5,"_32":142},"57e39e18-14b2-498a-add6-3e2db1aa84a9","parentId","latest",["D",1787052875199],"label",[33],"c6212ed6-1830-11f1-bd77-42dde27851f2","main.ts","d73071ea-fed2-11f0-a1dd-42dde27851f2",16,["D",1772673318659],14,"http","/**\n * Newsletter Signup API\n *\n * A simple HTTP endpoint for collecting email signups with flexible metadata storage.\n *\n * Features:\n * - Public signup endpoint (POST /subscribe) — returns subscriber id\n * - Public details endpoint (PUT /subscribe/:id/details) — merge additional info after signup\n * - Admin endpoints protected by API key (GET, PUT, DELETE /subscribers)\n * - Flexible JSON metadata field for arbitrary subscriber data\n * - Developer notes field for internal annotations\n * - SQLite storage with timestamps\n * - Duplicate emails allowed (de-duplicate downstream as needed)\n * - CORS enabled\n *\n * Environment Variables:\n * - ADMIN_API_KEY: Required for admin endpoints (passed via X-API-Key header)\n *\n * Schema:\n * - id: auto-incrementing primary key\n * - email: subscriber email (not unique)\n * - details: JSON blob for any metadata\n * - developer_notes: internal notes\n * - created_at, updated_at: timestamps\n */\n\nimport { sqlite } from \"https://esm.town/v/std/sqlite@14-main/main.ts\";\n\n// Simple auth check for admin endpoints\nfunction isAuthorized(req: Request): boolean {\n const apiKey = req.headers.get(\"X-API-Key\");\n const adminKey = Deno.env.get(\"ADMIN_API_KEY\");\n return !!adminKey && apiKey === adminKey;\n}\n\nfunction unauthorizedResponse(corsHeaders: Record): Response {\n return new Response(JSON.stringify({ error: \"Unauthorized\" }), {\n status: 401,\n headers: { \"Content-Type\": \"application/json\", ...corsHeaders },\n });\n}\n\n// Initialize the database table (no unique constraint on email - duplicates allowed, de-dupe later)\nawait sqlite.execute(`\n CREATE TABLE IF NOT EXISTS newsletter_subscribers (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n email TEXT NOT NULL,\n details TEXT,\n developer_notes TEXT,\n created_at TEXT DEFAULT (datetime('now')),\n updated_at TEXT DEFAULT (datetime('now'))\n )\n`);\n\nexport default async function(req: Request): Promise {\n const url = new URL(req.url);\n const corsHeaders = {\n \"Access-Control-Allow-Origin\": \"*\",\n \"Access-Control-Allow-Methods\": \"GET, POST, PUT, DELETE, OPTIONS\",\n \"Access-Control-Allow-Headers\": \"Content-Type, X-API-Key\",\n };\n\n // Handle CORS preflight\n if (req.method === \"OPTIONS\") {\n return new Response(null, { headers: corsHeaders });\n }\n\n try {\n // POST /subscribe - Sign up for newsletter\n if (req.method === \"POST\" && url.pathname === \"/subscribe\") {\n const body = await req.json();\n const { email, details } = body;\n\n if (!email || typeof email !== \"string\") {\n return new Response(JSON.stringify({ error: \"Email is required\" }), {\n status: 400,\n headers: { \"Content-Type\": \"application/json\", ...corsHeaders },\n });\n }\n\n // Basic email validation\n const emailRegex = /^[^\\s@]+@[^\\s@]+\\.[^\\s@]+$/;\n if (!emailRegex.test(email)) {\n return new Response(JSON.stringify({ error: \"Invalid email format\" }), {\n status: 400,\n headers: { \"Content-Type\": \"application/json\", ...corsHeaders },\n });\n }\n\n const insertResult = await sqlite.execute({\n sql: \"INSERT INTO newsletter_subscribers (email, details) VALUES (?, ?)\",\n args: [email.toLowerCase().trim(), details ? JSON.stringify(details) : null],\n });\n\n return new Response(JSON.stringify({\n success: true,\n message: \"Successfully subscribed!\",\n id: Number(insertResult.lastInsertRowid),\n }), {\n status: 201,\n headers: { \"Content-Type\": \"application/json\", ...corsHeaders },\n });\n }\n\n // PUT /subscribe/:id/details - Add/merge details for an existing subscription (public)\n if (req.method === \"PUT\" && url.pathname.match(/^\\/subscribe\\/\\d+\\/details$/)) {\n const id = url.pathname.split(\"/\")[2];\n const body = await req.json();\n const { details } = body;\n\n if (details === undefined || details === null || typeof details !== \"object\") {\n return new Response(JSON.stringify({ error: \"details object is required\" }), {\n status: 400,\n headers: { \"Content-Type\": \"application/json\", ...corsHeaders },\n });\n }\n\n // Fetch existing subscriber\n const existing = await sqlite.execute({\n sql: \"SELECT id, details FROM newsletter_subscribers WHERE id = ?\",\n args: [id],\n });\n\n if (existing.rows.length === 0) {\n return new Response(JSON.stringify({ error: \"Subscriber not found\" }), {\n status: 404,\n headers: { \"Content-Type\": \"application/json\", ...corsHeaders },\n });\n }\n\n // Merge new details into existing details (shallow merge)\n const existingDetails = existing.rows[0].details\n ? JSON.parse(existing.rows[0].details as string)\n : {};\n const mergedDetails = { ...existingDetails, ...details };\n\n await sqlite.execute({\n sql: \"UPDATE newsletter_subscribers SET details = ?, updated_at = datetime('now') WHERE id = ?\",\n args: [JSON.stringify(mergedDetails), id],\n });\n\n return new Response(JSON.stringify({\n success: true,\n message: \"Details updated\",\n details: mergedDetails,\n }), {\n headers: { \"Content-Type\": \"application/json\", ...corsHeaders },\n });\n }\n\n // GET /subscribers - List all subscribers (admin endpoint)\n if (req.method === \"GET\" && url.pathname === \"/subscribers\") {\n if (!isAuthorized(req)) return unauthorizedResponse(corsHeaders);\n \n const result = await sqlite.execute(\"SELECT * FROM newsletter_subscribers ORDER BY created_at DESC\");\n const subscribers = result.rows.map(row => ({\n id: row.id,\n email: row.email,\n details: row.details ? JSON.parse(row.details as string) : null,\n developer_notes: row.developer_notes,\n created_at: row.created_at,\n updated_at: row.updated_at,\n }));\n\n return new Response(JSON.stringify({ subscribers }), {\n headers: { \"Content-Type\": \"application/json\", ...corsHeaders },\n });\n }\n\n // PUT /subscribers/:id - Update subscriber (for developer notes)\n if (req.method === \"PUT\" && url.pathname.startsWith(\"/subscribers/\")) {\n if (!isAuthorized(req)) return unauthorizedResponse(corsHeaders);\n \n const id = url.pathname.split(\"/\")[2];\n const body = await req.json();\n const { details, developer_notes } = body;\n\n const updates: string[] = [];\n const args: any[] = [];\n\n if (details !== undefined) {\n updates.push(\"details = ?\");\n args.push(details ? JSON.stringify(details) : null);\n }\n if (developer_notes !== undefined) {\n updates.push(\"developer_notes = ?\");\n args.push(developer_notes);\n }\n\n if (updates.length === 0) {\n return new Response(JSON.stringify({ error: \"No fields to update\" }), {\n status: 400,\n headers: { \"Content-Type\": \"application/json\", ...corsHeaders },\n });\n }\n\n updates.push(\"updated_at = datetime('now')\");\n args.push(id);\n\n await sqlite.execute({\n sql: `UPDATE newsletter_subscribers SET ${updates.join(\", \")} WHERE id = ?`,\n args,\n });\n\n return new Response(JSON.stringify({ success: true, message: \"Subscriber updated\" }), {\n headers: { \"Content-Type\": \"application/json\", ...corsHeaders },\n });\n }\n\n // DELETE /subscribers/:id - Unsubscribe\n if (req.method === \"DELETE\" && url.pathname.startsWith(\"/subscribers/\")) {\n if (!isAuthorized(req)) return unauthorizedResponse(corsHeaders);\n \n const id = url.pathname.split(\"/\")[2];\n\n await sqlite.execute({\n sql: \"DELETE FROM newsletter_subscribers WHERE id = ?\",\n args: [id],\n });\n\n return new Response(JSON.stringify({ success: true, message: \"Subscriber removed\" }), {\n headers: { \"Content-Type\": \"application/json\", ...corsHeaders },\n });\n }\n\n // Default: show API documentation\n return new Response(JSON.stringify({\n name: \"Newsletter Signup API\",\n endpoints: {\n \"POST /subscribe\": {\n description: \"Subscribe to the newsletter. Returns subscriber id for follow-up calls.\",\n body: { email: \"string (required)\", details: \"object (optional metadata)\" },\n response: { success: \"boolean\", message: \"string\", id: \"number\" },\n },\n \"PUT /subscribe/:id/details\": {\n description: \"Add or update details for an existing subscriber (public, no auth). Shallow-merges with existing details.\",\n body: { details: \"object (required)\" },\n },\n \"GET /subscribers\": {\n description: \"List all subscribers (admin)\",\n },\n \"PUT /subscribers/:id\": {\n description: \"Update subscriber details or developer notes\",\n body: { details: \"object (optional)\", developer_notes: \"string (optional)\" },\n },\n \"DELETE /subscribers/:id\": {\n description: \"Remove a subscriber\",\n },\n },\n }), {\n headers: { \"Content-Type\": \"application/json\", ...corsHeaders },\n });\n\n } catch (error: any) {\n console.error(\"Error:\", error);\n return new Response(JSON.stringify({ error: \"Internal server error\", message: error.message }), {\n status: 500,\n headers: { \"Content-Type\": \"application/json\", ...corsHeaders },\n });\n }\n}\n",[144],"c50b37d2-7a79-4c51-a698-277f271e418f","db.ts","bddbfe22-9af8-11f1-9164-1607ee4eb77e",17,["D",1787052855294],"/**\n * Database schema + queries.\n *\n * Tables:\n * - newsletter_subscribers: signups (email + flexible JSON details + notes)\n * - ntfy_receivers: configurable ntfy.sh destinations for new-submission alerts\n * - ntfy_deliveries: audit log of notification attempts\n */\n\nimport { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\n\nexport type NtfyEvent = \"signup\" | \"details\";\n\nexport interface Subscriber {\n id: number;\n email: string;\n details: Record | null;\n developer_notes: string | null;\n created_at: string;\n updated_at: string;\n}\n\nexport interface Receiver {\n id: number;\n name: string;\n server: string;\n topic: string;\n priority: number;\n tags: string | null;\n /** ntfy access token (tk_…) or \"user:password\" for basic auth. */\n auth: string | null;\n /** Comma-separated list of NtfyEvent values. */\n events: string;\n enabled: number;\n created_at: string;\n updated_at: string;\n}\n\nexport interface Delivery {\n id: number;\n receiver_id: number | null;\n receiver_name: string;\n subscriber_id: number | null;\n event: string;\n ok: number;\n status: number | null;\n error: string | null;\n created_at: string;\n}\n\nawait sqlite.execute(`\n CREATE TABLE IF NOT EXISTS newsletter_subscribers (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n email TEXT NOT NULL,\n details TEXT,\n developer_notes TEXT,\n created_at TEXT DEFAULT (datetime('now')),\n updated_at TEXT DEFAULT (datetime('now'))\n )\n`);\n\nawait sqlite.execute(`\n CREATE TABLE IF NOT EXISTS ntfy_receivers (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n name TEXT NOT NULL,\n server TEXT NOT NULL DEFAULT 'https://ntfy.sh',\n topic TEXT NOT NULL,\n priority INTEGER NOT NULL DEFAULT 3,\n tags TEXT,\n auth TEXT,\n events TEXT NOT NULL DEFAULT 'signup',\n enabled INTEGER NOT NULL DEFAULT 1,\n created_at TEXT DEFAULT (datetime('now')),\n updated_at TEXT DEFAULT (datetime('now'))\n )\n`);\n\nawait sqlite.execute(`\n CREATE TABLE IF NOT EXISTS ntfy_deliveries (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n receiver_id INTEGER,\n receiver_name TEXT NOT NULL,\n subscriber_id INTEGER,\n event TEXT NOT NULL,\n ok INTEGER NOT NULL,\n status INTEGER,\n error TEXT,\n created_at TEXT DEFAULT (datetime('now'))\n )\n`);\n\nfunction parseDetails(raw: unknown): Record | null {\n if (!raw || typeof raw !== \"string\") return null;\n try {\n return JSON.parse(raw);\n } catch {\n return { _unparsed: raw };\n }\n}\n\nfunction toSubscriber(row: any): Subscriber {\n return {\n id: Number(row.id),\n email: String(row.email),\n details: parseDetails(row.details),\n developer_notes: row.developer_notes ?? null,\n created_at: String(row.created_at),\n updated_at: String(row.updated_at),\n };\n}\n\n/* ---------------------------------- subscribers --------------------------------- */\n\nexport async function insertSubscriber(email: string, details: unknown): Promise {\n const res = await sqlite.execute({\n sql: \"INSERT INTO newsletter_subscribers (email, details) VALUES (?, ?)\",\n args: [email, details ? JSON.stringify(details) : null],\n });\n return Number(res.lastInsertRowid);\n}\n\nexport async function getSubscriber(id: number | string): Promise {\n const res = await sqlite.execute({\n sql: \"SELECT * FROM newsletter_subscribers WHERE id = ?\",\n args: [id],\n });\n return res.rows.length ? toSubscriber(res.rows[0]) : null;\n}\n\nexport async function listSubscribers(limit = 500): Promise {\n const res = await sqlite.execute({\n sql: \"SELECT * FROM newsletter_subscribers ORDER BY id DESC LIMIT ?\",\n args: [limit],\n });\n return res.rows.map(toSubscriber);\n}\n\nexport async function countSubscribers(): Promise {\n const res = await sqlite.execute(\"SELECT COUNT(*) AS n FROM newsletter_subscribers\");\n return Number((res.rows[0] as any).n);\n}\n\n/** Shallow-merges `details` into the subscriber's existing details. */\nexport async function mergeSubscriberDetails(\n id: number | string,\n details: Record,\n): Promise | null> {\n const existing = await getSubscriber(id);\n if (!existing) return null;\n const merged = { ...(existing.details ?? {}), ...details };\n await sqlite.execute({\n sql: \"UPDATE newsletter_subscribers SET details = ?, updated_at = datetime('now') WHERE id = ?\",\n args: [JSON.stringify(merged), id],\n });\n return merged;\n}\n\nexport async function updateSubscriber(\n id: number | string,\n fields: { details?: unknown; developer_notes?: string },\n): Promise {\n const updates: string[] = [];\n const args: any[] = [];\n if (fields.details !== undefined) {\n updates.push(\"details = ?\");\n args.push(fields.details ? JSON.stringify(fields.details) : null);\n }\n if (fields.developer_notes !== undefined) {\n updates.push(\"developer_notes = ?\");\n args.push(fields.developer_notes);\n }\n if (!updates.length) return false;\n updates.push(\"updated_at = datetime('now')\");\n args.push(id);\n await sqlite.execute({\n sql: `UPDATE newsletter_subscribers SET ${updates.join(\", \")} WHERE id = ?`,\n args,\n });\n return true;\n}\n\nexport async function deleteSubscriber(id: number | string): Promise {\n await sqlite.execute({\n sql: \"DELETE FROM newsletter_subscribers WHERE id = ?\",\n args: [id],\n });\n}\n\n/* ----------------------------------- receivers ---------------------------------- */\n\nfunction toReceiver(row: any): Receiver {\n return {\n id: Number(row.id),\n name: String(row.name),\n server: String(row.server),\n topic: String(row.topic),\n priority: Number(row.priority),\n tags: row.tags ?? null,\n auth: row.auth ?? null,\n events: String(row.events),\n enabled: Number(row.enabled),\n created_at: String(row.created_at),\n updated_at: String(row.updated_at),\n };\n}\n\nexport async function listReceivers(): Promise {\n const res = await sqlite.execute(\"SELECT * FROM ntfy_receivers ORDER BY id ASC\");\n return res.rows.map(toReceiver);\n}\n\nexport async function getReceiver(id: number | string): Promise {\n const res = await sqlite.execute({\n sql: \"SELECT * FROM ntfy_receivers WHERE id = ?\",\n args: [id],\n });\n return res.rows.length ? toReceiver(res.rows[0]) : null;\n}\n\n/** Enabled receivers subscribed to a given event. */\nexport async function receiversForEvent(event: NtfyEvent): Promise {\n const all = await listReceivers();\n return all.filter(r =>\n r.enabled && r.events.split(\",\").map(e => e.trim()).includes(event)\n );\n}\n\nexport type ReceiverInput = {\n name: string;\n server: string;\n topic: string;\n priority: number;\n tags: string | null;\n auth: string | null;\n events: string;\n enabled: number;\n};\n\nexport async function createReceiver(input: ReceiverInput): Promise {\n const res = await sqlite.execute({\n sql: `INSERT INTO ntfy_receivers (name, server, topic, priority, tags, auth, events, enabled)\n VALUES (?, ?, ?, ?, ?, ?, ?, ?)`,\n args: [\n input.name,\n input.server,\n input.topic,\n input.priority,\n input.tags,\n input.auth,\n input.events,\n input.enabled,\n ],\n });\n return Number(res.lastInsertRowid);\n}\n\nexport async function updateReceiver(\n id: number | string,\n input: Partial,\n): Promise {\n const updates: string[] = [];\n const args: any[] = [];\n for (const [key, value] of Object.entries(input)) {\n if (value === undefined) continue;\n updates.push(`${key} = ?`);\n args.push(value as any);\n }\n if (!updates.length) return;\n updates.push(\"updated_at = datetime('now')\");\n args.push(id);\n await sqlite.execute({\n sql: `UPDATE ntfy_receivers SET ${updates.join(\", \")} WHERE id = ?`,\n args,\n });\n}\n\nexport async function deleteReceiver(id: number | string): Promise {\n await sqlite.execute({ sql: \"DELETE FROM ntfy_receivers WHERE id = ?\", args: [id] });\n}\n\n/* ---------------------------------- deliveries ---------------------------------- */\n\nexport async function logDelivery(entry: {\n receiver_id: number | null;\n receiver_name: string;\n subscriber_id: number | null;\n event: string;\n ok: boolean;\n status: number | null;\n error: string | null;\n}): Promise {\n await sqlite.execute({\n sql: `INSERT INTO ntfy_deliveries (receiver_id, receiver_name, subscriber_id, event, ok, status, error)\n VALUES (?, ?, ?, ?, ?, ?, ?)`,\n args: [\n entry.receiver_id,\n entry.receiver_name,\n entry.subscriber_id,\n entry.event,\n entry.ok ? 1 : 0,\n entry.status,\n entry.error,\n ],\n });\n}\n\nexport async function recentDeliveries(limit = 25): Promise {\n const res = await sqlite.execute({\n sql: \"SELECT * FROM ntfy_deliveries ORDER BY id DESC LIMIT ?\",\n args: [limit],\n });\n return res.rows.map((row: any) => ({\n id: Number(row.id),\n receiver_id: row.receiver_id === null ? null : Number(row.receiver_id),\n receiver_name: String(row.receiver_name),\n subscriber_id: row.subscriber_id === null ? null : Number(row.subscriber_id),\n event: String(row.event),\n ok: Number(row.ok),\n status: row.status === null ? null : Number(row.status),\n error: row.error ?? null,\n created_at: String(row.created_at),\n }));\n}\n",[153],"be6f3280-fed3-11f0-bfa2-42dde27851f2","README.md","be6f332a-fed3-11f0-bfa2-42dde27851f2",11,["D",1769884583495],"# Newsletter Signup API\n\nEmail signup endpoint with flexible metadata storage and admin management.\n\n## Features\n\n- **Public signup endpoint** - `POST /subscribe`\n- **Protected admin endpoints** - List, update, and delete subscribers\n- **Flexible metadata** - `details` field accepts any JSON\n- **Developer notes** - Internal annotations per subscriber\n- **Duplicate emails allowed** - De-duplicate downstream as needed\n- **SQLite storage** - Timestamps for created/updated\n- **CORS enabled**\n\n## Setup\n\nSet the `ADMIN_API_KEY` environment variable to protect admin endpoints.\n\n## Endpoints\n\n| Method | Path | Auth | Description |\n|--------|------|------|-------------|\n| POST | `/subscribe` | Public | Submit a signup |\n| GET | `/subscribers` | API Key | List all subscribers |\n| PUT | `/subscribers/:id` | API Key | Update details or notes |\n| DELETE | `/subscribers/:id` | API Key | Remove a subscriber |\n\n## Usage\n\n**Subscribe (public):**\n```bash\ncurl -X POST https://YOUR_ENDPOINT/subscribe \\\n -H \"Content-Type: application/json\" \\\n -d '{\"email\": \"user@example.com\", \"details\": {\"any\": \"json\"}}'\n```\n\n**Admin requests:**\n```bash\ncurl https://YOUR_ENDPOINT/subscribers \\\n -H \"X-API-Key: your-admin-key\"\n```\n\n## Schema\n\n| Column | Type | Description |\n|--------|------|-------------|\n| `id` | INTEGER | Auto-incrementing primary key |\n| `email` | TEXT | Subscriber email |\n| `details` | TEXT | JSON metadata (flexible) |\n| `developer_notes` | TEXT | Internal notes |\n| `created_at` | TEXT | Submission timestamp |\n| `updated_at` | TEXT | Last update timestamp |\n",[160],"pulls","branches",1,"forks","envVars",{"_174":65,"_176":65},"connections",{"_174":65,"_175":65},"count","unfilledCount","emptyCount",{"_47":159,"_37":160,"_35":161,"_138":-5,"_45":46,"_44":162,"_139":30,"_42":191,"_13":65,"_38":26,"_40":164,"_29":30,"_141":-5,"_182":192,"_32":193},{"_47":152,"_37":153,"_35":154,"_138":-5,"_45":46,"_44":155,"_139":30,"_42":188,"_13":65,"_38":39,"_40":157,"_29":30,"_141":-5,"_182":189,"_32":190},{"_47":143,"_37":144,"_35":145,"_138":-5,"_45":46,"_44":146,"_139":30,"_42":185,"_13":148,"_38":149,"_40":150,"_29":30,"_141":49,"_182":186,"_32":187},{"_47":137,"_37":33,"_35":36,"_138":-5,"_45":46,"_44":14,"_139":30,"_42":181,"_13":65,"_38":39,"_40":41,"_29":30,"_141":-5,"_182":183,"_32":184},["D",1787052875199],"children",[],[33],["D",1772673318659],[],[144],["D",1787052855294],[],[153],["D",1769884583495],[],[160],["D",1769884195507],["D",1789534231467],{"_102":101,"_109":105},{"_102":101,"_103":-5,"_104":105,"_19":59,"_106":107,"_108":30},{"_13":91,"_37":92,"_47":46,"_93":48,"_94":-5,"_95":-5,"_96":-5,"_97":-5,"_98":-5,"_99":49,"_100":101},"ctx",{"_84":-5,"_130":232,"_233":234,"_235":236,"_237":30,"_238":30,"_239":30,"_240":128,"_241":-5,"_242":-7,"_243":-7,"_244":65,"_245":30,"_246":30,"_247":-5,"_248":30,"_249":30,"_250":30,"_251":-5},"ENV",{"_203":204,"_205":206,"_207":92,"_208":209,"_210":211,"_212":213,"_214":215,"_216":217,"_218":219,"_220":221,"_222":223,"_224":225,"_226":227,"_228":229,"_230":231},"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 · v18