⚠️ Errors in the Last Hour

\n \n \n \n \n \n \n \n \n \n ${rows}\n

Time	Status	Duration	Error

\n `;\n }\n\n const html = `\n

${statusEmoji} Dan Polling — Hourly Report

${now}

Endpoint: ${ENDPOINT}

\n\n

Last Hour

\n \n \n \n \n \n \n

Polls	${h.total}
Uptime	${hourUptime}%
Avg Response	${h.avg_ms ?? \"—\"}ms
Min / Max	${h.min_ms ?? \"—\"}ms / ${h.max_ms ?? \"—\"}ms
Errors	0 ? \"#dc2626\" : \"#16a34a\"};\">${h.errors}

\n\n

All Time

\n \n \n \n \n \n

Total Polls	${a.total}
Uptime	${allTimeUptime}%
Avg Response	${a.avg_ms}ms
Total Errors	${a.errors}

\n\n ${errorSection}\n\n

\n Sent from dan-polling on Val Town\n

\n `;\n\n const subject = `${statusEmoji} Dan Polling: ${hourUptime}% uptime, ${h.total} polls, ${h.errors} errors (last hour)`;\n\n await email({\n subject,\n html,\n });\n\n console.log(`Hourly email sent: ${subject}`);\n}\n",[138],"7c641b46-19b6-11f1-8c34-42dde27851f2","dashboard.tsx",["D",1772840698670],15,"http","/** @jsxImportSource npm:hono@4/jsx */\nimport { Hono } from \"npm:hono@4\";\nimport { sqlite } from \"https://esm.town/v/std/sqlite@14-main/main.ts\";\n\nconst app = new Hono();\n\nconst ENDPOINT = \"https://gaearon--d1b4d53009e511f1933c42dde27851f2.web.val.run/.well-known/did.json\";\n\nfunction Layout({ children }: { children: any }) {\n return (\n \n \n Dan Polling\n \n \n \n \n

\n {children}\n

\n \n \n );\n}\n\nfunction formatDuration(ms: number): string {\n if (ms >= 1000) return `${(ms / 1000).toFixed(2)}s`;\n return `${Math.round(ms)}ms`;\n}\n\nfunction StatCard({ label, value, sub, icon }: { label: string; value: string; sub?: string; icon: string }) {\n return (\n

\n {icon}\n {label}\n

{value}

\n {sub &&

{sub}

}\n

\n );\n}\n\nfunction ResponseChart(\n { data, width, height }: { data: { time: string; ms: number; error: boolean }[]; width: number; height: number },\n) {\n if (data.length < 2) {\n return (\n

\n Not enough data for chart yet\n

\n );\n }\n\n const padTop = 30;\n const padBottom = 40;\n const padLeft = 60;\n const padRight = 20;\n const chartW = width - padLeft - padRight;\n const chartH = height - padTop - padBottom;\n\n const maxMs = Math.max(...data.map((d) => d.ms));\n const minMs = Math.min(...data.map((d) => d.ms));\n\n const logMin = Math.floor(Math.log10(Math.max(1, minMs) * 0.8));\n const logMax = Math.ceil(Math.log10(maxMs * 1.2));\n const yLogMin = Math.pow(10, logMin);\n const yLogMax = Math.pow(10, logMax);\n\n function msToY(ms: number): number {\n const clamped = Math.max(yLogMin, ms);\n const logNorm = (Math.log10(clamped) - Math.log10(yLogMin)) / (Math.log10(yLogMax) - Math.log10(yLogMin));\n return padTop + chartH - logNorm * chartH;\n }\n\n const points = data.map((d, i) => {\n const x = padLeft + (i / (data.length - 1)) * chartW;\n const y = msToY(d.ms);\n return { x, y, ...d };\n });\n\n const linePath = points.map((p, i) => `${i === 0 ? \"M\" : \"L\"}${p.x.toFixed(1)},${p.y.toFixed(1)}`).join(\" \");\n const areaPath = linePath\n + ` L${points[points.length - 1].x.toFixed(1)},${padTop + chartH} L${points[0].x.toFixed(1)},${padTop + chartH} Z`;\n\n const logTicks: number[] = [];\n const niceMultipliers = [1, 2, 5];\n for (let exp = logMin; exp <= logMax; exp++) {\n for (const m of niceMultipliers) {\n const val = m * Math.pow(10, exp);\n if (val >= yLogMin && val <= yLogMax) logTicks.push(val);\n }\n }\n\n const yLines = logTicks.map((val) => ({ val, y: msToY(val) }));\n\n // X-axis: show day labels\n const xLabelCount = Math.min(7, data.length);\n const xLabels = Array.from({ length: xLabelCount }, (_, i) => {\n const idx = Math.round((i / (xLabelCount - 1)) * (data.length - 1));\n const d = new Date(data[idx].time);\n const label = `${d.getUTCMonth() + 1}/${d.getUTCDate()} ${d.getUTCHours().toString().padStart(2, \"0\")}:${\n d.getUTCMinutes().toString().padStart(2, \"0\")\n }`;\n const x = padLeft + (idx / (data.length - 1)) * chartW;\n return { label, x };\n });\n\n const avgMs = data.reduce((s, d) => s + d.ms, 0) / data.length;\n const avgY = msToY(avgMs);\n\n return (\n

\n Response Time{\" \"}\n (log scale)\n

\n {data.length} data points\n

\n \n

\n );\n}\n\napp.get(\"/\", async (c) => {\n const oneWeekAgo = new Date(Date.now() - 7 * 24 * 60 * 60 * 1000).toISOString();\n\n // Chart data (last week, oldest first)\n const chartResult = await sqlite.execute({\n sql: `SELECT started_at, duration_ms, error FROM poll_log WHERE started_at >= ? ORDER BY id ASC`,\n args: [oneWeekAgo],\n });\n const chartData = (chartResult.rows as any[]).map((r: any) => ({\n time: r.started_at,\n ms: r.duration_ms,\n error: r.error !== null,\n }));\n\n // Stats for the last week only\n const statsResult = await sqlite.execute({\n sql: `SELECT\n COUNT(*) as total,\n ROUND(AVG(duration_ms), 1) as avg_ms,\n MIN(duration_ms) as min_ms,\n MAX(duration_ms) as max_ms,\n SUM(CASE WHEN error IS NOT NULL THEN 1 ELSE 0 END) as errors,\n SUM(CASE WHEN status_code != 200 THEN 1 ELSE 0 END) as non_200\n FROM poll_log\n WHERE started_at >= ?`,\n args: [oneWeekAgo],\n });\n const stats = statsResult.rows[0] as any;\n\n const uptimePct = stats.total > 0\n ? ((stats.total - (stats.errors || 0) - (stats.non_200 || 0)) / stats.total * 100).toFixed(2)\n : \"N/A\";\n\n // Last poll time\n const lastPollResult = await sqlite.execute({\n sql: `SELECT started_at, duration_ms, status_code, error FROM poll_log WHERE started_at >= ? ORDER BY id DESC LIMIT 1`,\n args: [oneWeekAgo],\n });\n const lastPoll = lastPollResult.rows[0] as any | undefined;\n\n const lastPollAgo = lastPoll\n ? (() => {\n const diff = Date.now() - new Date(lastPoll.started_at).getTime();\n const mins = Math.floor(diff / 60000);\n if (mins < 1) return \"just now\";\n if (mins < 60) return `${mins}m ago`;\n return `${Math.floor(mins / 60)}h ${mins % 60}m ago`;\n })()\n : \"—\";\n\n return c.html(\n \n {/* Header */}\n

Dan Polling

{ENDPOINT}

\n\n {/* Stats */}\n

\n \n \n \n \n

\n\n {/* Chart */}\n \n\n {/* Footer */}\n

\n Polling every minute · Last 7 days · Powered by Val Town\n

\n ,\n );\n});\n\nexport default app.fetch;\n",[146],"d0a83d9a-0f34-11f1-b70e-42dde27851f2","README.md","d0a83e3a-0f34-11f1-b70e-42dde27851f2",10,["D",1771685493850],"# dan-polling\n\nMonitors Dan's ATProto DID endpoint every minute, stores results in SQLite, and sends an hourly email digest.\n\n## Architecture\n\n```mermaid\nflowchart TD\n A[\"⏱️ main.ts\\n(every 1 min)\"] -->|\"fetch\"| B[\"Dan's DID Endpoint\\n.well-known/did.json\"]\n B -->|\"status + duration\"| A\n A -->|\"INSERT\"| C[(\"🗄️ SQLite\\npoll_log\")]\n\n D[\"⏱️ hourly-email.ts\\n(every 1 hour)\"] -->|\"SELECT stats\"| C\n D -->|\"send digest\"| E[\"📧 Email\\n(std/email)\"]\n\n F[\"🌐 dashboard.tsx\\n(HTTP)\"] -->|\"SELECT logs + stats\"| C\n G[\"👤 User\"] -->|\"HTTP GET\"| F\n```\n\n## Files\n\n| File | Type | Description |\n|---|---|---|\n| `main.ts` | Interval (1 min) | Polls the endpoint, records status code & latency into SQLite |\n| `hourly-email.ts` | Interval (1 hr) | Queries SQLite for stats and sends an HTML email digest |\n| `dashboard.tsx` | HTTP | Web dashboard showing response time chart, stats, and poll log |\n\n## Database\n\nUses a val-scoped SQLite database (`std/sqlite@14-main`) with a single table:\n\n```sql\nCREATE TABLE poll_log (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n started_at TEXT NOT NULL,\n ended_at TEXT NOT NULL,\n duration_ms INTEGER NOT NULL,\n status_code INTEGER,\n error TEXT\n);\n```\n\n## Email\n\nHourly digest emails are sent via [`std/email`](https://esm.town/v/std/email) and include:\n\n- **Last hour**: poll count, uptime %, avg/min/max response time, error count\n- **All time**: total polls, uptime %, avg response time, total errors\n- **Error table**: recent failures with timestamps, status codes, and messages\n",[153],"pulls",1,"forks","envVars",{"_166":54,"_168":54},"connections",{"_166":54,"_167":54},"count","unfilledCount","emptyCount",{"_20":152,"_13":153,"_121":154,"_123":-5,"_124":21,"_125":155,"_127":50,"_22":183,"_29":54,"_130":104,"_132":157,"_134":38,"_135":-5,"_174":184,"_93":185},{"_20":145,"_13":146,"_121":48,"_123":-5,"_124":21,"_125":30,"_127":50,"_22":180,"_29":148,"_130":149,"_132":150,"_134":38,"_135":-5,"_174":181,"_93":182},{"_20":137,"_13":138,"_121":139,"_123":-5,"_124":21,"_125":140,"_127":50,"_22":177,"_29":142,"_130":131,"_132":143,"_134":38,"_135":-5,"_174":178,"_93":179},{"_20":119,"_13":120,"_121":122,"_123":-5,"_124":21,"_125":126,"_127":50,"_22":173,"_29":129,"_130":131,"_132":133,"_134":38,"_135":-5,"_174":175,"_93":176},["D",1771626326623],"children",[],[120],["D",1771710036944],[],[138],["D",1772840698670],[],[146],["D",1771685493850],[],[153],["D",1771626241697],["D",1789444252033],{"_11":12,"_91":87},{"_11":12,"_85":-5,"_86":87,"_45":46,"_88":89,"_90":38},{"_29":30,"_13":26,"_20":21,"_27":28,"_31":-5,"_32":-5,"_80":-5,"_81":-5,"_82":-5,"_83":14,"_84":12},"ctx",{"_73":-5,"_112":224,"_225":226,"_227":228,"_229":38,"_230":38,"_231":38,"_232":50,"_233":-5,"_234":-7,"_235":-7,"_236":54,"_237":38,"_238":38,"_239":-5,"_240":38,"_241":38,"_242":38,"_243":-5},"ENV",{"_195":196,"_197":198,"_199":26,"_200":201,"_202":203,"_204":205,"_206":207,"_208":209,"_210":211,"_212":213,"_214":215,"_216":217,"_218":219,"_220":221,"_222":223},"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