/** @jsxImportSource https://esm.sh/react */ import { DateTime } from "https://cdn.skypack.dev/luxon@2.3.2"; import { extractValInfo } from "https://esm.town/v/pomdtr/extractValInfo?v=27"; import { sqlite } from "https://esm.town/v/std/sqlite?v=6"; import { renderToString } from "npm:react-dom/server"; const { author, name, httpEndpoint } = extractValInfo(import.meta.url); sqlite.batch([ { sql: `CREATE TABLE IF NOT EXISTS ${name}_impressions ( id INTEGER PRIMARY KEY, timestamp TEXT NOT NULL DEFAULT (datetime('now')), val TEXT NOT NULL, event_name TEXT, url TEXT, meta TEXT );`, args: [], }, ]); const getRunningValInfo = () => { const urlOfRunningVal = (new Error()).stack.split("\n").at(-1).split(" ").at(-1).split(":").slice(0, 2).join(":"); return extractValInfo(urlOfRunningVal); }; export const initAnalytics = () => { try { const runningValInfo = getRunningValInfo(); if (runningValInfo.author == author && runningValInfo.name == name) { // If we happen to have imported ourself, don't report import analytics. Would loop. return; } // Do not await the response fetch(`${httpEndpoint}/event?name=import-init&val=${runningValInfo.author}/${runningValInfo.name}`); } catch (e) { console.error(`Error initializing analytics: ${e}`); } }; export const analyticsHandlerWrapper = ( handler: (req: Request) => Response | Promise, ): (req: Request) => Response | Promise => { const runningValInfo = getRunningValInfo(); return async (req: Request): Promise => { fetch(`${httpEndpoint}/event?name=request&val=${runningValInfo.author}/${runningValInfo.name}&url=${req.url}`); return handler(req); }; }; const valCounts = async (): Promise<{ count: number; val: string }[]> => { const result = await sqlite.execute( `select val, count(*) as count from ${name}_impressions group by val order by count desc limit 100`, ); return (result.rows as [string, number][]).map((row) => ({ count: row[1], val: row[0] })); }; const queryForImpressions = async ( val: string, start: string, end: string, intervalMinutes: number, timeZone: string, ) => { const startDate = DateTime.fromISO(start, { zone: "utc" }).setZone(timeZone); const endDate = DateTime.fromISO(end, { zone: "utc" }).setZone(timeZone); const startString = startDate.toFormat("yyyy-MM-dd HH:mm:ss"); const endString = endDate.toFormat("yyyy-MM-dd HH:mm:ss"); return await sqlite.execute({ sql: ` WITH params AS ( SELECT ? AS interval_minutes, ? AS start_time, ? AS end_time ) SELECT strftime('%Y-%m-%d %H:%M:00', datetime( (strftime('%s', timestamp) / (interval_minutes * 60)) * (interval_minutes * 60), 'unixepoch' )) AS bucket, COUNT(*) AS count FROM ${name}_impressions, params WHERE timestamp BETWEEN start_time AND end_time AND val = ? GROUP BY bucket ORDER BY bucket`, args: [intervalMinutes, startString, endString, val], }); }; async function handler(req: Request): Promise { const url = new URL(req.url); if (req.method === "GET" && url.pathname === "/event") { const val = url.searchParams.get("val"); const eventName = url.searchParams.get("name"); const eventUrl = url.searchParams.get("url"); if (!val || !eventName) { return new Response("invalid", { status: 400 }); } let resp = await sqlite.execute({ sql: `INSERT INTO ${name}_impressions (val, event_name, url) VALUES (?, ?, ?) RETURNING *`, args: [val, eventName, eventUrl], }); return Response.json(resp); } if (req.method === "GET" && url.pathname === "/query") { const resp = await queryForImpressions( "maxm/orangeRattlesnake", (new Date((new Date()).getTime() - 24 * 60 * 60 * 1000)).toISOString(), (new Date((new Date()).getTime() + 24 * 60 * 60 * 1000)).toISOString(), 10, "America/New_York", ); return Response.json(resp); } if (req.method === "GET" && url.pathname.startsWith("/v/")) { const resp = await queryForImpressions( url.pathname.slice(3), (new Date((new Date()).getTime() - 24 * 60 * 60 * 1000)).toISOString(), (new Date((new Date()).getTime() + 24 * 60 * 60 * 1000)).toISOString(), 10, "America/New_York", ); return Response.json(resp); } const vals = await valCounts(); return new Response( renderToString(

Val Town Analytics

{vals.map((val) => ( ))}

Vals
{val.val}	{val.count}

, ), { headers: { "content-type": "text/html" }, }, ); } export default handler;

valTownAnalytics