std/email delivery status

\n\n

\n \n \n {latest\n ? up\n ? `Operational — last email delivered in ${((latest.latency_ms ?? 0) / 1000).toFixed(1)}s`\n : `Down — last test: ${latest.status}`\n : \"No test results yet\"}\n \n

\n {latest && (\n

\n Last tested {new Date(latest.sent_at).toUTCString()} · runs every 15 minutes\n

\n )}\n\n

\n Delivery latency (last {chart.length} tests)\n

\n {(() => {\n const W = 640, H = 200;\n const PAD = { left: 44, right: 12, top: 12, bottom: 24 };\n const plotW = W - PAD.left - PAD.right;\n const plotH = H - PAD.top - PAD.bottom;\n const x = (i: number) =>\n PAD.left + (chart.length > 1 ? (i / (chart.length - 1)) * plotW : plotW / 2);\n const y = (ms: number) => PAD.top + plotH - (ms / maxLatency) * plotH;\n const ticks = [0, maxLatency / 2, maxLatency];\n const ok = chart\n .map((r, i) => ({ r, i }))\n .filter(({ r }) => r.latency_ms !== null);\n const line = ok\n .map(({ r, i }, j) => `${j === 0 ? \"M\" : \"L\"}${x(i).toFixed(1)},${y(r.latency_ms!).toFixed(1)}`)\n .join(\" \");\n return (\n \n );\n })()}\n

\n green = delivered · amber = slow (>30s) · red dot at top = failed\n

\n\n

\n \n view source\n \n

\n \n ,\n );\n});\n\nexport default app.fetch;\n",[18,104],"667b811b-674c-44ae-b065-680fa480f84c",["D",1787339036517],6,"import { email } from \"https://esm.town/v/std/email\";\nimport { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\nimport { emailAddress, parseVal } from \"https://esm.town/v/std/utils/index.ts\";\n\nconst POLL_INTERVAL_MS = 1_000;\nconst TIMEOUT_MS = 2 * 60_000;\nconst SLOW_THRESHOLD_MS = 30_000;\n\nasync function alert(message: string) {\n const webhookUrl = Deno.env.get(\"SLACK_WEBHOOK_URL\");\n if (!webhookUrl) {\n console.warn(\"SLACK_WEBHOOK_URL not set; would have alerted:\", message);\n return;\n }\n const editUrl = parseVal().links.self.latest;\n await fetch(webhookUrl, {\n method: \"POST\",\n headers: { \"Content-Type\": \"application/json\" },\n body: JSON.stringify({\n text: `🚨 std/email test: ${message}\\n✏️ <${editUrl}|Edit Val>`,\n }),\n });\n}\n\nasync function recordResult(\n probeId: string,\n sentAt: number,\n receivedAt: number | null,\n status: \"ok\" | \"slow\" | \"timeout\" | \"send_error\",\n error?: string,\n) {\n await sqlite.execute({\n sql: `INSERT OR REPLACE INTO email_test_results\n (probe_id, sent_at, received_at, latency_ms, status, error)\n VALUES (?, ?, ?, ?, ?, ?)`,\n args: [\n probeId,\n sentAt,\n receivedAt,\n receivedAt ? receivedAt - sentAt : null,\n status,\n error ?? null,\n ],\n });\n}\n\nexport default async function runTests() {\n const probeId = crypto.randomUUID();\n const to = await emailAddress(\"tests/receiver.ts\");\n const sentAt = Date.now();\n\n try {\n await email({\n to,\n subject: probeId,\n text: \"std/email delivery test probe\",\n });\n } catch (e) {\n await recordResult(probeId, sentAt, null, \"send_error\", String(e));\n await alert(`send failed: ${e}`);\n return;\n }\n\n while (Date.now() - sentAt < TIMEOUT_MS) {\n const { rows } = await sqlite.execute({\n sql: `SELECT received_at FROM email_test_received WHERE probe_id = ?`,\n args: [probeId],\n });\n if (rows.length) {\n const receivedAt = Number(rows[0][0]);\n const latency = receivedAt - sentAt;\n const slow = latency > SLOW_THRESHOLD_MS;\n await recordResult(probeId, sentAt, receivedAt, slow ? \"slow\" : \"ok\");\n if (slow) {\n await alert(\n `email delivered but slow: ${(latency / 1000).toFixed(1)}s`,\n );\n } else console.log(`ok: delivered in ${latency}ms`);\n return;\n }\n await new Promise((r) => setTimeout(r, POLL_INTERVAL_MS));\n }\n\n await recordResult(probeId, sentAt, null, \"timeout\");\n await alert(\n `email not received within ${TIMEOUT_MS / 1000}s (probe ${probeId})`,\n );\n}",[18,94],"7538e693-c8db-4cba-9050-8f430a162ae0",["D",1783969700738],4,"import { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\n\n// Dumb pipe: writes every incoming email's subject (the probe id) + timestamp to sqlite.\n// The runner (tests/runner.ts) polls this table to confirm delivery.\nexport default async function (e: { subject?: string }) {\n await sqlite.execute({\n sql:\n `INSERT INTO email_test_received (probe_id, received_at) VALUES (?, ?)`,\n args: [e.subject ?? \"(no subject)\", Date.now()],\n });\n}",[18,79],"pulls","branches",2,"forks","envVars",{"_316":310,"_318":26},"connections",{"_316":26,"_317":26},"count","unfilledCount","emptyCount",{"_48":283,"_13":18,"_77":206,"_58":-5,"_50":51,"_284":55,"_285":24,"_52":352,"_54":26,"_80":207,"_287":-5,"_81":30,"_288":-5,"_332":353,"_17":354},{"_48":303,"_13":79,"_77":78,"_58":206,"_50":51,"_284":143,"_285":24,"_52":349,"_54":305,"_80":14,"_287":306,"_81":30,"_288":-5,"_332":350,"_17":351},{"_48":298,"_13":94,"_77":93,"_58":206,"_50":51,"_284":201,"_285":24,"_52":346,"_54":300,"_80":95,"_287":301,"_81":30,"_288":-5,"_332":347,"_17":348},{"_48":293,"_13":104,"_77":103,"_58":206,"_50":51,"_284":108,"_285":24,"_52":343,"_54":295,"_80":105,"_287":296,"_81":30,"_288":-5,"_332":344,"_17":345},{"_48":335,"_13":336,"_77":337,"_58":-5,"_50":51,"_284":338,"_285":24,"_52":339,"_54":295,"_80":21,"_287":340,"_81":30,"_288":-5,"_332":341,"_17":342},{"_48":325,"_13":326,"_77":327,"_58":-5,"_50":51,"_284":328,"_285":24,"_52":329,"_54":330,"_80":171,"_287":331,"_81":30,"_288":-5,"_332":333,"_17":334},"ba80d2f4-25fe-11f0-b0b8-569c3dd06744","main.tsx","ba4a80e6-25fe-11f0-b0b8-569c3dd06744",14,["D",1722442459613],13,"import { API_URL } from \"https://esm.town/v/std/API_URL\";\nimport { parseSendGridEmail } from \"https://esm.town/v/stevekrouse/parseSendGridEmail?v=8\";\nimport { parseSendGridEmails } from \"https://esm.town/v/stevekrouse/parseSendGridEmails?v=10\";\n\n/**\n * Send emails. You can only send emails to yourself if\n * you’re on Val Town Free. If you’re on Val Town Pro,\n * you can email anyone. ([Docs ↗](https://docs.val.town/std/email))\n */\nexport const email = async (data: {\n /**\n * The email address(es) to send the email to. Only available to Val Town Pro subscribers.\n * Can be a single string, IAddress object, or an array of strings/IAddress objects.\n * @default the email of the logged user calling this function.\n */\n to?: (IAddress | string)[] | IAddress | string;\n\n /**\n * The email address to set as the \"from\" address. It can only be set to username.valname@valtown.email addresses.\n * Can be a string or IAddress object.\n * @default notifications@val.town\n */\n from?: IAddress | string;\n\n /**\n * The email address(es) to CC on the email. Only available to Val Town Pro subscribers.\n * Can be a single string, IAddress object, or an array of strings/IAddress objects.\n */\n cc?: (IAddress | string)[] | IAddress | string;\n\n /**\n * The email address(es) to blind carbon copy (BCC) on the email. Only available to Val Town Pro subscribers.\n * Can be a single string, IAddress object, or an array of strings/IAddress objects.\n */\n bcc?: (IAddress | string)[] | IAddress | string;\n\n /**\n * The subject line for the email.\n */\n subject?: string;\n\n /**\n * The email address(es) to set as the \"reply-to\" address.\n * Can be a single string, IAddress object, or an array of strings/IAddress objects.\n */\n replyTo?: (IAddress | string)[] | IAddress | string;\n\n /**\n * The HTML content for the email body.\n */\n html?: string;\n\n /**\n * The plain text content for the email body.\n */\n text?: string;\n\n /**\n * An array of attachment data to include with the email.\n */\n attachments?: AttachmentData[];\n\n /**\n * Headers to include in the email. For example, you could add\n * a custom header like X-Custom-Header to indicate some extra data\n * you don't want to include the in body.\n */\n headers?: Record;\n}) => {\n let result = await fetch(\n `${API_URL}/v1/email`,\n {\n method: \"POST\",\n body: JSON.stringify({\n to: parseSendGridEmails(data.to),\n from: data.from && parseSendGridEmail(data.from),\n cc: parseSendGridEmails(data.cc),\n bcc: parseSendGridEmails(data.bcc),\n replyToList: parseSendGridEmails(data.replyTo),\n subject: data.subject,\n html: data.html,\n text: data.text,\n attachments: data.attachments,\n headers: data.headers,\n }),\n headers: {\n authorization: \"Bearer \" + Deno.env.get(\"valtown\"),\n },\n },\n ).then(r => r.json());\n if (result?.message !== \"Email accepted to be sent\") {\n let message = result?.message ?? result?.error ?? JSON.stringify(result);\n throw new Error(\"Val Town Email Error: \" + message);\n }\n return result;\n};\n\nexport interface IAddress {\n email: string;\n name?: string;\n}\n\nexport interface AttachmentData {\n content: string;\n filename: string;\n type?: string;\n disposition?: string;\n contentId?: string;\n}","children",[],[326],"9e7e6a1e-dd2b-11f0-84fd-42dde27851f2","README.md","ba4aa4c2-25fe-11f0-b0b8-569c3dd06744",15,["D",1766183986081],"# Email - [Docs ↗](https://docs.val.town/std/email)\n\nSend emails with [`std/email`](https://www.val.town/v/std/email). You can only\nsend emails to yourself if you're on Val Town Free. If you're on\n[Val Town Pro](https://www.val.town/pricing), you can email anyone.\n\nWant to receive emails instead?\n[Create an email handler val](https://docs.val.town/types/email/)\n\n## Basic usage\n\n```ts\nimport { email } from \"https://esm.town/v/std/email\";\n\nawait email({\n subject: \"New Ink & Switch Post!\",\n text: \"https://www.inkandswitch.com/embark/\",\n});\n```\n\n### `subject`\n\nThe email subject line. It defaults to\n`Message from @your_username on Val Town`.\n\n### `to`, `cc`, and `bcc`\n\nBy default, the `to` field is set to the owner of the Val Town account that\ncalls it.\n\nIf you have Val Town Pro, you can send emails to anyone via the `to`, `cc`, and\n`bcc` fields.\n\nIf you don't have Val Town Pro, you can only send emails to yourself, so leave\nthose fields blank.\n\n### `from`\n\nThe `from` is limited to a few options:\n\n1. It defaults to `notifications@val.town` if you don't specify it.\n\n2. If you do specify it, it must be of the form:\n\n- `{ email: \"your_username.valname@valtown.email }\"` or\n- `{ email: \"your_username.valname@valtown.email\", name: \"Sender Name\" }`.\n\n### `replyTo`\n\n`replyTo` accepts a string email or an object with strings for `email` and\n`name` (optional).\n\nThis can be useful if you are sending emails to others with Val Town Pro.\n\n```ts title=\"replyTo\" val\nimport { email } from \"https://esm.town/v/std/email\";\n\nawait email({\n to: \"someone_else@example.com\",\n from: \"your_username.valname@valtown.email\",\n replyTo: \"your_email@example.com\",\n text: \"these pretzels are making me thirsty\",\n});\n```\n\n### Attachments\n\nYou can attach files to your emails by using the `attachments` field.\nAttachments need to be [Base64](https://en.wikipedia.org/wiki/Base64) encoded,\nwhich is what the [btoa](https://developer.mozilla.org/en-US/docs/Web/API/btoa)\nmethod is doing in this example:\n\n```ts title=\"Attachments example\" val\nimport { email } from \"https://esm.town/v/std/email\";\n\nexport const stdEmailAttachmentExample = email({\n attachments: [\n {\n content: btoa(\"hello attachments!\"),\n filename: \"test.txt\",\n type: \"text\",\n disposition: \"attachment\",\n },\n ],\n});\n```\n\nHere's an example sending a [PDF](https://www.val.town/v/stevekrouse/sendPDF).\n\n### Headers\n\nYou can set custom headers in emails that you send:\n\n```ts title=\"Custom headers example\" val\nimport { email } from \"https://esm.town/v/std/email?v=13\";\n\nconsole.log(\n await email({\n text: \"Hi\",\n headers: {\n \"X-Custom-Header\": \"xxx\",\n },\n }),\n);\n```\n\nThis is also\n[documented in our REST API](https://docs.val.town/openapi#/tag/emails/POST/v1/email),\nand supported in the [SDK](https://docs.val.town/api/sdk/).\n\n[📝 Edit docs](https://github.com/val-town/val-town-docs/edit/main/src/content/docs/std/email.md)\n\nMigrated from folder: email/email",[],[336],["D",1783969646786],[],[18,104],["D",1787339036517],[],[18,94],["D",1783969700738],[],[18,79],["D",1783969404810],[320,321,322],[18],["D",1746043642565],["D",1789559472742],{"_11":12,"_261":257},{"_11":12,"_256":-5,"_84":257,"_31":-5,"_258":259,"_260":30},{"_54":201,"_13":16,"_48":51,"_248":209,"_249":-5,"_250":-5,"_251":-5,"_252":-5,"_253":-5,"_254":14,"_255":12},"ctx",{"_67":-5,"_280":393,"_394":395,"_396":397,"_398":30,"_399":30,"_400":30,"_401":24,"_402":-5,"_403":-7,"_404":-7,"_405":26,"_406":30,"_407":30,"_408":-5,"_409":30,"_410":30,"_411":30,"_412":-5},"ENV",{"_364":365,"_366":367,"_368":16,"_369":370,"_371":372,"_373":374,"_375":376,"_377":378,"_379":380,"_381":382,"_383":384,"_385":386,"_387":388,"_389":390,"_391":392},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","RENDER_GIT_COMMIT","811aa22498c9b0b5a47e8d778de579cdb990f332","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 · tests