⚠️ 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",[132],"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",[140],"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",[147],"pulls","branches",1,"forks","envVars",{"_161":42,"_163":42},"connections",{"_161":42,"_162":42},"count","unfilledCount","emptyCount",{"_18":146,"_20":147,"_115":148,"_117":-5,"_118":71,"_119":149,"_121":38,"_22":178,"_68":42,"_124":98,"_126":151,"_128":26,"_129":-5,"_169":179,"_88":180},{"_18":139,"_20":140,"_115":36,"_117":-5,"_118":71,"_119":69,"_121":38,"_22":175,"_68":142,"_124":143,"_126":144,"_128":26,"_129":-5,"_169":176,"_88":177},{"_18":131,"_20":132,"_115":133,"_117":-5,"_118":71,"_119":134,"_121":38,"_22":172,"_68":136,"_124":125,"_126":137,"_128":26,"_129":-5,"_169":173,"_88":174},{"_18":113,"_20":114,"_115":116,"_117":-5,"_118":71,"_119":120,"_121":38,"_22":168,"_68":123,"_124":125,"_126":127,"_128":26,"_129":-5,"_169":170,"_88":171},["D",1771626326623],"children",[],[114],["D",1771710036944],[],[132],["D",1772840698670],[],[140],["D",1771685493850],[],[147],["D",1771626241697],["D",1789531243171],{"_16":17,"_86":82},{"_16":17,"_80":-5,"_81":82,"_33":34,"_83":84,"_85":26},{"_68":69,"_20":70,"_18":71,"_72":19,"_73":-5,"_74":-5,"_75":-5,"_76":-5,"_77":-5,"_78":21,"_79":17},"ctx",{"_61":-5,"_106":219,"_220":221,"_222":223,"_224":26,"_225":26,"_226":26,"_227":38,"_228":-5,"_229":-7,"_230":-7,"_231":42,"_232":26,"_233":26,"_234":-5,"_235":26,"_236":26,"_237":26,"_238":-5},"ENV",{"_190":191,"_192":193,"_194":70,"_195":196,"_197":198,"_199":200,"_201":202,"_203":204,"_205":206,"_207":208,"_209":210,"_211":212,"_213":214,"_215":216,"_217":218},"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"]

Search