[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_195":196,"_197":198},"routes/_app.x.$handle.$name",{"_100":99,"_32":45,"_108":90,"_27":53,"_13":14,"_109":-5,"_11":110,"_111":112,"_113":114,"_115":116,"_117":118,"_20":-5,"_119":-5,"_120":-5,"_121":25,"_122":123,"_124":59,"_125":-5,"_126":-5,"_127":128},"routes/_app.x.$handle.$name.branch.$branch.version.$version.diff",{"_11":12,"_13":14,"_15":16,"_17":-5,"_18":-5},"project",{"_43":44,"_32":45,"_38":46,"_47":-5,"_48":25,"_49":50,"_51":50,"_52":53,"_54":53,"_18":55,"_56":57,"_58":59,"_60":-5,"_61":-5,"_62":63,"_64":65,"_66":67,"_68":69,"_70":71,"_72":-5,"_73":74,"_75":74,"_76":77,"_78":77,"_79":77,"_80":74,"_81":74,"_82":83,"_84":85,"_86":87,"_88":25},"version",13,"changes",[19],"aiChatInfo","userId",{"_20":21,"_22":23,"_24":25,"_26":25,"_27":28,"_29":28},"file",{"_30":31,"_32":28,"_33":37,"_35":36,"_38":39,"_40":14,"_41":42,"_24":25},"previous",{"_30":31,"_32":28,"_33":34,"_35":36},"deleted",false,"deletedHere","path","hourly-email.ts","latestPath","fileId","2c071972-0eae-11f1-a55d-42dde27851f2","name","fileType","script","content","import { email } from \"https://esm.town/v/std/email\";\nimport { sqlite } from \"https://esm.town/v/std/sqlite@14-main/main.ts\";\n\nconst ENDPOINT = \"https://gaearon--d1b4d53009e511f1933c42dde27851f2.web.val.run/.well-known/did.json\";\n\nexport default async function() {\n // Stats for the last hour\n const hourResult = await sqlite.execute(\n `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 > datetime('now', '-1 hour')`\n );\n const h = hourResult.rows[0] as any;\n\n // All-time stats\n const allResult = await sqlite.execute(\n `SELECT\n COUNT(*) as total,\n ROUND(AVG(duration_ms), 1) as avg_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 );\n const a = allResult.rows[0] as any;\n\n // Recent errors (last hour)\n const errorsResult = await sqlite.execute(\n `SELECT started_at, status_code, error, duration_ms\n FROM poll_log\n WHERE (error IS NOT NULL OR status_code != 200)\n AND started_at > datetime('now', '-1 hour')\n ORDER BY id DESC\n LIMIT 10`\n );\n const recentErrors = errorsResult.rows as any[];\n\n const allTimeUptime = a.total > 0\n ? ((a.total - a.errors - a.non_200) / a.total * 100).toFixed(2)\n : \"N/A\";\n\n const hourUptime = h.total > 0\n ? ((h.total - h.errors - h.non_200) / h.total * 100).toFixed(2)\n : \"N/A\";\n\n const hasIssues = h.errors > 0 || h.non_200 > 0;\n const statusEmoji = hasIssues ? \"🔴\" : \"🟢\";\n const now = new Date().toISOString().replace(\"T\", \" \").slice(0, 19) + \" UTC\";\n\n let errorSection = \"\";\n if (recentErrors.length > 0) {\n const rows = recentErrors\n .map(\n (e: any) =>\n `\n ${new Date(e.started_at).toISOString().slice(11, 19)}\n ${e.status_code ?? \"—\"}\n ${e.duration_ms}ms\n ${e.error || \"non-200\"}\n `,\n )\n .join(\"\\n\");\n\n errorSection = `\n

⚠️ 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","interval","createdAt",["D",1771710036944],"branchVersion","branchId","db9efafc-0eaa-11f1-b08d-42dde27851f2","id","db9e8fc2-0eaa-11f1-b08d-42dde27851f2","dan-polling",["D",1771626241697],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","","imageUrl","a0bf3b31-15a5-4d5c-880e-4b1e22c9bc18","pinnedFileId","1e2fed92-0eae-11f1-8950-42dde27851f2","pinPreview",true,"pinMigrated","screenshotVersion","likeCount",0,"orgId","e81e7335-6d4c-4764-a902-d0962bbfa9f7","tursoName","db9e8fc20eaa11f1b08d42dde27851f2","tursoHostname","db9e8fc20eaa11f1b08d42dde27851f2-val-town.aws-us-east-2.turso.io","tursoMeasuredAt",["D",1789531243171],"pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_100":99,"_107":103},"org",{"_100":99,"_101":-5,"_102":103,"_18":55,"_104":105,"_106":25},"branch",{"_13":89,"_32":90,"_43":42,"_91":44,"_92":-5,"_93":-5,"_94":-5,"_95":-5,"_96":-5,"_97":45,"_98":99},"isOwned",25,"main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","stevekrouse","handle","displayName","avatar","https://images.clerk.dev/uploaded/img_2PqHa2Gsy93xQrjh2w78Xu0cChW.jpeg","tier","pro","canRestrictVals","profileImageUrl","branchName","adoptOrgId",{"_43":44,"_32":45,"_38":190,"_47":-5,"_48":25,"_49":50,"_51":50,"_52":53,"_54":53,"_18":55,"_56":57,"_58":59,"_60":-5,"_61":-5,"_62":63,"_64":65,"_66":67,"_68":69,"_70":191,"_72":-5,"_73":74,"_75":74,"_76":77,"_78":77,"_79":77,"_80":74,"_81":74,"_82":192,"_84":193,"_86":194,"_88":25},"tree",[173,174,175,176],"files",[173,174,175,176],"counts",{"_162":63,"_163":164,"_165":63,"_166":167,"_168":169},"contents",[129,130,131,132],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},{"_43":155,"_32":156,"_30":157,"_136":-5,"_41":42,"_40":158,"_138":59,"_38":159,"_13":63,"_33":20,"_35":160,"_24":25,"_142":-5,"_27":161},{"_43":148,"_32":149,"_30":57,"_136":-5,"_41":42,"_40":150,"_138":25,"_38":151,"_13":137,"_33":152,"_35":153,"_24":25,"_142":-5,"_27":154},{"_43":144,"_32":28,"_30":31,"_136":-5,"_41":42,"_40":14,"_138":59,"_38":145,"_13":146,"_33":37,"_35":36,"_24":25,"_142":-5,"_27":147},{"_43":133,"_32":134,"_30":135,"_136":-5,"_41":42,"_40":137,"_138":59,"_38":139,"_13":140,"_33":37,"_35":141,"_24":25,"_142":-5,"_27":143},"0e3eba2e-0eab-11f1-8a33-42dde27851f2","main.ts","dba1c25a-0eaa-11f1-b08d-42dde27851f2","parentId",3,"latest",["D",1771626326623],2,"import { sqlite } from \"https://esm.town/v/std/sqlite@14-main/main.ts\";\n\nconst ENDPOINT = \"https://gaearon--d1b4d53009e511f1933c42dde27851f2.web.val.run/.well-known/did.json\";\n\nexport default async function() {\n const startedAt = new Date();\n let statusCode: number | null = null;\n let error: string | null = null;\n\n try {\n const res = await fetch(ENDPOINT);\n statusCode = res.status;\n // consume body to complete the request\n await res.text();\n } catch (e) {\n error = e instanceof Error ? e.message : String(e);\n }\n\n const endedAt = new Date();\n const durationMs = endedAt.getTime() - startedAt.getTime();\n\n await sqlite.execute({\n sql: `INSERT INTO poll_log (started_at, ended_at, duration_ms, status_code, error)\n VALUES (?, ?, ?, ?, ?)`,\n args: [startedAt.toISOString(), endedAt.toISOString(), durationMs, statusCode, error],\n });\n\n console.log(`Polled ${ENDPOINT} — status: ${statusCode}, duration: ${durationMs}ms${error ? `, error: ${error}` : \"\"}`);\n}\n","label",[134],"f57beb06-0f6d-11f1-87ed-42dde27851f2",["D",1771710036944],4,[28],"11f09e90-0ecd-11f1-be60-42dde27851f2","dashboard.tsx",8,["D",1771640935709],"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, title }: { children: any; title: string }) {\n return (\n \n \n {title}\n \n \n \n \n

\n {children}\n

\n \n \n );\n}\n\nfunction StatusBadge({ code, error }: { code: number | null; error: string | null }) {\n if (error) {\n return ERROR;\n }\n if (code && code >= 200 && code < 300) {\n return {code};\n }\n if (code && code >= 400) {\n return {code};\n }\n return {code ?? \"?\"};\n}\n\nfunction DurationBar({ ms, maxMs }: { ms: number; maxMs: number }) {\n const pct = Math.min(100, Math.round((ms / maxMs) * 100));\n const color = ms < 300 ? \"bg-green-500\" : ms < 500 ? \"bg-yellow-500\" : \"bg-red-500\";\n return (\n

\n {ms}ms\n

\n );\n}\n\nfunction StatCard({ label, value, sub }: { label: string; value: string; sub?: string }) {\n return (\n

{label}

{value}

\n {sub &&

{sub}

}\n

\n );\n}\n\nfunction ResponseChart({ data, width, height }: { data: { time: string; ms: number; error: boolean }[]; width: number; height: number }) {\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 = 50;\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 const yMax = Math.ceil(maxMs / 100) * 100;\n const yMin = 0;\n\n const points = data.map((d, i) => {\n const x = padLeft + (i / (data.length - 1)) * chartW;\n const y = padTop + chartH - ((d.ms - yMin) / (yMax - yMin)) * chartH;\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 + ` L${points[points.length - 1].x.toFixed(1)},${padTop + chartH} L${points[0].x.toFixed(1)},${padTop + chartH} Z`;\n\n // Y-axis gridlines\n const yTicks = 5;\n const yLines = Array.from({ length: yTicks + 1 }, (_, i) => {\n const val = yMin + ((yMax - yMin) / yTicks) * i;\n const y = padTop + chartH - (i / yTicks) * chartH;\n return { val: Math.round(val), y };\n });\n\n // X-axis labels (show ~6)\n const xLabelCount = Math.min(6, 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.getUTCHours().toString().padStart(2, \"0\")}:${d.getUTCMinutes().toString().padStart(2, \"0\")}`;\n const x = padLeft + (idx / (data.length - 1)) * chartW;\n return { label, x };\n });\n\n // Avg line\n const avgMs = data.reduce((s, d) => s + d.ms, 0) / data.length;\n const avgY = padTop + chartH - ((avgMs - yMin) / (yMax - yMin)) * chartH;\n\n return (\n

Response Time

\n Last {data.length} polls\n

\n \n

\n );\n}\n\napp.get(\"/\", async (c) => {\n const page = parseInt(c.req.query(\"page\") || \"1\");\n const perPage = 50;\n const offset = (page - 1) * perPage;\n\n // Chart data (all polls, oldest first)\n const chartResult = await sqlite.execute(\n `SELECT started_at, duration_ms, error FROM poll_log ORDER BY id ASC`\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 // Aggregate stats\n const statsResult = await sqlite.execute(\n `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 MIN(started_at) as first_poll,\n MAX(started_at) as last_poll\n FROM poll_log`\n );\n const stats = statsResult.rows[0] as any;\n\n // Last hour stats\n const hourResult = await sqlite.execute(\n `SELECT\n COUNT(*) as total,\n ROUND(AVG(duration_ms), 1) as avg_ms,\n SUM(CASE WHEN error IS NOT NULL THEN 1 ELSE 0 END) as errors\n FROM poll_log\n WHERE started_at > datetime('now', '-1 hour')`\n );\n const hourStats = hourResult.rows[0] as any;\n\n // Uptime percentage\n const uptimePct = stats.total > 0\n ? ((stats.total - stats.errors - stats.non_200) / stats.total * 100).toFixed(2)\n : \"N/A\";\n\n // Recent poll entries\n const logsResult = await sqlite.execute({\n sql: `SELECT * FROM poll_log ORDER BY id DESC LIMIT ? OFFSET ?`,\n args: [perPage, offset],\n });\n const logs = logsResult.rows as any[];\n\n // Count for pagination\n const totalCount = stats.total as number;\n const totalPages = Math.ceil(totalCount / perPage);\n\n return c.html(\n \n

📡 Dan Polling Dashboard

Monitoring: {ENDPOINT}

\n \n ↻ Refresh\n \n

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

\n \n \n \n \n

\n\n {/* Response Time Chart */}\n \n\n {/* Log Table */}\n

Recent Polls

\n \n \n \n \n \n \n \n \n \n \n \n {logs.map((log: any) => (\n \n \n \n \n \n \n \n ))}\n \n

#	Time	Status	Duration	Error
{log.id}	\n {new Date(log.started_at).toLocaleString(\"en-US\", {\n month: \"short\", day: \"numeric\",\n hour: \"2-digit\", minute: \"2-digit\", second: \"2-digit\",\n hour12: false,\n })}\n	\n \n	\n \n	\n {log.error \|\| \"—\"}\n

\n\n {/* Pagination */}\n {totalPages > 1 && (\n

\n \n Page {page} of {totalPages} ({totalCount} total)\n \n

\n {page > 1 && (\n \n ← Prev\n \n )}\n {page < totalPages && (\n \n Next →\n \n )}\n

\n )}\n

\n\n

\n Polling every 1 minute · Powered by Val Town\n

\n \n );\n});\n\nexport default app.fetch;\n",[149],"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",[156],"pulls","branches",1,"forks","envVars",{"_170":63,"_172":63},"connections",{"_170":63,"_171":63},"count","unfilledCount","emptyCount",{"_43":155,"_32":156,"_30":157,"_136":-5,"_41":42,"_40":158,"_138":59,"_38":187,"_13":63,"_33":20,"_35":160,"_24":25,"_142":-5,"_178":188,"_27":189},{"_43":148,"_32":149,"_30":57,"_136":-5,"_41":42,"_40":150,"_138":25,"_38":184,"_13":137,"_33":152,"_35":153,"_24":25,"_142":-5,"_178":185,"_27":186},{"_43":144,"_32":28,"_30":31,"_136":-5,"_41":42,"_40":14,"_138":59,"_38":181,"_13":146,"_33":37,"_35":36,"_24":25,"_142":-5,"_178":182,"_27":183},{"_43":133,"_32":134,"_30":135,"_136":-5,"_41":42,"_40":137,"_138":59,"_38":177,"_13":140,"_33":37,"_35":141,"_24":25,"_142":-5,"_178":179,"_27":180},["D",1771626326623],"children",[],[134],["D",1771710036944],[],[28],["D",1771640935709],[],[149],["D",1771685493850],[],[156],["D",1771626241697],["D",1789531243171],{"_100":99,"_107":103},{"_100":99,"_101":-5,"_102":103,"_18":55,"_104":105,"_106":25},{"_13":89,"_32":90,"_43":42,"_91":44,"_92":-5,"_93":-5,"_94":-5,"_95":-5,"_96":-5,"_97":45,"_98":99},"ctx",{"_82":-5,"_126":228,"_229":230,"_231":232,"_233":25,"_234":25,"_235":25,"_236":59,"_237":-5,"_238":-7,"_239":-7,"_240":63,"_241":25,"_242":25,"_243":-5,"_244":25,"_245":25,"_246":25,"_247":-5},"ENV",{"_199":200,"_201":202,"_203":90,"_204":205,"_206":207,"_208":209,"_210":211,"_212":213,"_214":215,"_216":217,"_218":219,"_220":221,"_222":223,"_224":225,"_226":227},"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 · v13