ValTown Project Analytics

Reusable event ingest and browser client for lightweight analytics across multiple Val Town projects.

Endpoints

GET  /client.js\nPOST /track\nGET  /summary?project=guess-that-hype\nGET  /events?project=guess-that-hype&limit=25

Quick Start

<script src=\"${origin}/client.js\" defer></script>\n<script defer>\n  window.addEventListener(\"DOMContentLoaded\", function () {\n    const analytics = window.ValTownAnalytics.init({\n      endpoint: \"${origin}/track\",\n      project: \"my-project\",\n    });\n\n    analytics.track(\"page_ready\", { area: \"landing\" });\n  });\n</script>

\n \n`;\n}\n\nfunction clientJs(origin: string) {\n return `(function () {\n var STORAGE_KEY = \"vt_project_analytics_session_v1\";\n var state = {\n endpoint: ${JSON.stringify(origin + \"/track\")},\n project: \"\",\n globalProps: {},\n sessionId: null,\n debug: false,\n };\n\n function randomId() {\n if (window.crypto && window.crypto.randomUUID) {\n return window.crypto.randomUUID();\n }\n return \"vt-\" + Date.now().toString(36) + \"-\" + Math.random().toString(36).slice(2, 10);\n }\n\n function getSessionId() {\n if (state.sessionId) return state.sessionId;\n try {\n var existing = window.localStorage.getItem(STORAGE_KEY);\n if (existing) {\n state.sessionId = existing;\n return existing;\n }\n var created = randomId();\n window.localStorage.setItem(STORAGE_KEY, created);\n state.sessionId = created;\n return created;\n } catch (_error) {\n state.sessionId = randomId();\n return state.sessionId;\n }\n }\n\n function send(payload) {\n var body = JSON.stringify(payload);\n if (state.debug) console.log(\"[ValTownAnalytics]\", payload);\n if (navigator.sendBeacon && body.length < 60000) {\n var blob = new Blob([body], { type: \"application/json\" });\n if (navigator.sendBeacon(state.endpoint, blob)) return Promise.resolve(true);\n }\n return fetch(state.endpoint, {\n method: \"POST\",\n headers: { \"content-type\": \"application/json\" },\n body: body,\n keepalive: true,\n mode: \"cors\",\n }).then(function () { return true; }).catch(function () { return false; });\n }\n\n function track(event, props) {\n if (!state.project || !event) return Promise.resolve(false);\n return send({\n project: state.project,\n event: event,\n sessionId: getSessionId(),\n pagePath: window.location.pathname,\n pageUrl: window.location.href,\n referrer: document.referrer || null,\n source: \"browser\",\n ts: new Date().toISOString(),\n props: Object.assign({}, state.globalProps, props || {}),\n });\n }\n\n window.ValTownAnalytics = {\n init: function init(config) {\n config = config || {};\n state.endpoint = config.endpoint || state.endpoint;\n state.project = config.project || state.project;\n state.globalProps = config.globalProps || {};\n state.debug = Boolean(config.debug);\n getSessionId();\n return {\n track: track,\n sessionId: function () { return getSessionId(); },\n };\n },\n track: track,\n };\n})();`;\n}\n\nfunction safeString(value: unknown, max = 255) {\n if (typeof value !== \"string\") return null;\n const trimmed = value.trim();\n if (!trimmed) return null;\n return trimmed.slice(0, max);\n}\n\nfunction safeProps(value: unknown) {\n if (!value || typeof value !== \"object\" || Array.isArray(value)) return {};\n const jsonValue = JSON.stringify(value);\n if (!jsonValue) return {};\n if (jsonValue.length <= 6000) return value;\n return { truncated: true, preview: jsonValue.slice(0, 5900) };\n}\n\nfunction eventId() {\n return crypto.randomUUID();\n}\n\nasync function ingest(req: Request) {\n await ensureSchema();\n\n let body: any;\n try {\n body = await req.json();\n } catch {\n return json({ ok: false, error: \"invalid_json\" }, { status: 400 });\n }\n\n const project = safeString(body?.project, 120);\n const event = safeString(body?.event, 120);\n if (!project || !event) {\n return json({ ok: false, error: \"project_and_event_required\" }, { status: 400 });\n }\n\n const props = safeProps(body?.props);\n await sqlite.execute({\n sql: `INSERT INTO events (\n id, project, event, session_id, page_path, page_url, referrer, source, user_agent, ts, props_json\n ) VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)`,\n args: [\n eventId(),\n project,\n event,\n safeString(body?.sessionId, 120),\n safeString(body?.pagePath, 500),\n safeString(body?.pageUrl, 1000),\n safeString(body?.referrer, 1000),\n safeString(body?.source, 60),\n safeString(req.headers.get(\"user-agent\"), 500),\n safeString(body?.ts, 64) || new Date().toISOString(),\n JSON.stringify(props),\n ],\n });\n\n return json({ ok: true });\n}\n\nasync function summary(project: string) {\n await ensureSchema();\n const totals = await sqlite.execute({\n sql: `SELECT event, COUNT(*) AS count FROM events WHERE project = ? GROUP BY event ORDER BY count DESC, event ASC`,\n args: [project],\n });\n const latest = await sqlite.execute({\n sql: `SELECT ts, event, props_json FROM events WHERE project = ? ORDER BY ts DESC LIMIT 10`,\n args: [project],\n });\n const sessions = await sqlite.execute({\n sql: `SELECT COUNT(DISTINCT session_id) AS count FROM events WHERE project = ?`,\n args: [project],\n });\n\n return {\n project,\n uniqueSessions: sessions.rows?.[0]?.count ?? 0,\n events: totals.rows ?? [],\n latest: (latest.rows ?? []).map((row: any) => ({\n ts: row.ts,\n event: row.event,\n props: JSON.parse(row.props_json || \"{}\"),\n })),\n };\n}\n\nasync function recentEvents(project: string, limit: number) {\n await ensureSchema();\n const rows = await sqlite.execute({\n sql: `SELECT ts, event, session_id, page_path, props_json FROM events WHERE project = ? ORDER BY ts DESC LIMIT ?`,\n args: [project, limit],\n });\n return (rows.rows ?? []).map((row: any) => ({\n ts: row.ts,\n event: row.event,\n sessionId: row.session_id,\n pagePath: row.page_path,\n props: JSON.parse(row.props_json || \"{}\"),\n }));\n}\n\nexport default async function handler(req: Request): Promise {\n const url = new URL(req.url);\n const origin = url.origin;\n\n if (req.method === \"OPTIONS\") {\n return new Response(null, { status: 204, headers: CORS_HEADERS });\n }\n\n if (req.method === \"GET\" && url.pathname === \"/\") {\n return html(pageHtml(origin));\n }\n\n if (req.method === \"GET\" && url.pathname === \"/client.js\") {\n return javascript(clientJs(origin));\n }\n\n if (req.method === \"POST\" && url.pathname === \"/track\") {\n return ingest(req);\n }\n\n if (req.method === \"GET\" && url.pathname === \"/summary\") {\n const project = safeString(url.searchParams.get(\"project\"), 120);\n if (!project) return json({ ok: false, error: \"project_required\" }, { status: 400 });\n return json(await summary(project));\n }\n\n if (req.method === \"GET\" && url.pathname === \"/events\") {\n const project = safeString(url.searchParams.get(\"project\"), 120);\n const limit = Math.min(Number(url.searchParams.get(\"limit\") || 25), 100);\n if (!project) return json({ ok: false, error: \"project_required\" }, { status: 400 });\n return json({ project, events: await recentEvents(project, limit) });\n }\n\n return json({ ok: false, error: \"not_found\" }, { status: 404 });\n}\n","deleted","label",[109],"2ec9dcca-239a-11f1-972d-42dde27851f2","README.md","91baabde-2395-11f1-9eea-42dde27851f2",["D",1773928054187],"# ValTown Project Analytics\n\nPublic Val Town analytics service:\n- https://www.val.town/x/pchinjr/valtown_project_analytics\n\nLive service:\n- https://pchinjr--2dfdceb4239511f1baa142dde27851f2.web.val.run\n\n## Overview\n\n`valtown_project_analytics` is a reusable analytics service for lightweight event tracking across multiple Val Town projects.\n\nIt provides:\n- a browser client script you can drop into any Val Town app\n- an ingest endpoint for event writes\n- simple JSON reporting endpoints for summaries and recent events\n- shared storage using Val Town global SQLite\n\nThis is intentionally small and pragmatic. It is meant for meaningful product events, not full session replay or enterprise analytics workflows.\n\n## Routes\n\n- `GET /`\n Human-readable landing page with usage notes\n- `GET /client.js`\n Reusable browser client\n- `POST /track`\n Event ingest endpoint\n- `GET /summary?project=`\n Per-project summary with unique sessions, totals, and recent events\n- `GET /events?project=&limit=25`\n Recent per-project event stream\n- `OPTIONS *`\n CORS preflight handling\n\n## Data Model\n\nEvents are stored in a shared SQLite table named `events`.\n\nColumns:\n- `id`\n- `project`\n- `event`\n- `session_id`\n- `page_path`\n- `page_url`\n- `referrer`\n- `source`\n- `user_agent`\n- `ts`\n- `received_at`\n- `props_json`\n\nIndexes:\n- `idx_events_project_ts`\n- `idx_events_project_event_ts`\n\n## Browser Integration\n\n```html\n\n\n```\n\n## Client API\n\n`window.ValTownAnalytics.init(config)` accepts:\n- `project`\n- `endpoint` optional override\n- `globalProps` optional object merged into every event\n- `debug` optional boolean\n\nIt returns:\n- `track(event, props)`\n- `sessionId()`\n\nBehavior:\n- generates and persists a browser session id in `localStorage`\n- uses `navigator.sendBeacon` when available\n- falls back to `fetch` with `keepalive`\n\n## Event Shape\n\n```json\n{\n \"project\": \"guess-that-hype\",\n \"event\": \"quiz_started\",\n \"sessionId\": \"vt-...\",\n \"pagePath\": \"/\",\n \"pageUrl\": \"https://example.web.val.run/\",\n \"referrer\": \"https://example.com/\",\n \"source\": \"browser\",\n \"ts\": \"2026-03-19T13:00:00.000Z\",\n \"props\": {\n \"runId\": \"...\",\n \"questionsPerRun\": 8\n }\n}\n```\n\n## Recommended Metrics\n\n- `page_viewed`\n- `quiz_started`\n- `question_answered`\n- `quiz_completed`\n- `share_clicked`\n- `share_copied`\n- `cta_clicked`\n\n## Tradeoffs\n\nGood fit for:\n- custom event analytics across several Val Town projects\n- product funnels and lightweight reporting\n- simple owner-controlled instrumentation\n\nNot designed for:\n- session replay\n- identity stitching across devices\n- advanced cohort analysis\n- enterprise-scale analytics workloads\n\n## Files\n\n- `main.ts`\n Full analytics service implementation\n- `README.md`\n Project documentation\n",[126],"pulls","branches","forks","envVars",{"_138":40,"_140":40},"connections",{"_138":40,"_139":40},"count","unfilledCount","emptyCount",{"_18":125,"_20":126,"_110":127,"_112":-5,"_113":66,"_114":64,"_116":101,"_22":147,"_63":115,"_118":94,"_120":129,"_122":26,"_123":-5,"_144":148,"_83":149},{"_18":108,"_20":109,"_110":111,"_112":-5,"_113":66,"_114":115,"_116":101,"_22":143,"_63":40,"_118":119,"_120":121,"_122":26,"_123":-5,"_144":145,"_83":146},["D",1773925905380],"children",[],[109],["D",1773928054187],[],[126],["D",1773925905345],{"_16":17,"_81":77},{"_16":17,"_75":-5,"_76":77,"_33":34,"_78":79,"_80":26},{"_63":64,"_20":65,"_18":66,"_67":19,"_68":-5,"_69":-5,"_70":-5,"_71":-5,"_72":-5,"_73":21,"_74":17},"ctx",{"_56":-5,"_103":187,"_188":189,"_190":191,"_192":26,"_193":26,"_194":26,"_195":101,"_196":-5,"_197":-7,"_198":-7,"_199":40,"_200":26,"_201":26,"_202":-5,"_203":26,"_204":26,"_205":26,"_206":-5},"ENV",{"_158":159,"_160":161,"_162":65,"_163":164,"_165":166,"_167":168,"_169":170,"_171":172,"_173":174,"_175":176,"_177":178,"_179":180,"_181":182,"_183":184,"_185":186},"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