[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_168":169,"_170":171},"routes/_app.x.$handle.$name",{"_11":12,"_13":14,"_15":-7,"_61":87,"_16":-7,"_138":-5,"_17":139,"_140":141,"_28":142,"_21":143,"_23":144,"_145":-5,"_146":-5,"_147":-5,"_148":35,"_149":150,"_151":38,"_152":-5,"_153":-5,"_154":155},"routes/_app.x.$handle.$name._index",{"_11":12,"_13":14,"_15":-7,"_16":-7,"_17":18,"_19":20,"_21":22,"_23":24,"_25":-7,"_26":-5,"_27":-5,"_28":29,"_30":31,"_32":-5,"_33":-5,"_34":35,"_36":35,"_37":38},"handle","rishabhagarwal","name","health-receiver","branchName","version","project",{"_39":79,"_13":14,"_50":80,"_81":-5,"_82":35,"_83":84,"_85":84,"_86":87,"_88":-5,"_89":90,"_91":43,"_92":38,"_93":-5,"_94":-5,"_95":67,"_96":97,"_98":99,"_100":101,"_102":103,"_104":-5,"_105":106,"_107":106,"_108":109,"_110":109,"_111":109,"_112":106,"_113":106,"_114":115,"_116":117,"_118":119,"_120":35},"tags",[],"counts",{"_66":67,"_68":69,"_70":67,"_71":72,"_73":74},"contents",[63],"readme","upstream","pull","files",[31],"preview",{"_39":40,"_13":41,"_42":43,"_44":-5,"_45":46,"_47":48,"_49":38,"_50":51,"_16":52,"_53":54,"_55":56,"_57":35,"_58":-5,"_59":60,"_61":62},"ahead","behind","showHomeCustomizationHint",false,"showHTTPPreviewSettingsHint","hasHTTPFiles",true,"id","d8980fdf-553b-4f06-8a4f-f33be4bc58d2","health-receiver.ts","fileId","7d8203b0-8eed-11f1-9245-1607ee4eb77e","parentId","branchId","22084898-5451-44a0-bcc7-4a3dd2bc4ba2","branchVersion",16,"latest","createdAt",["D",1785730703083],13,"fileType","http","content","// Health receiver v3 — persistent store\n//\n// Accepts Health Auto Export -format payloads (also emitted by Health Export AI)\n// and keeps every point in SQLite, upserting by (metric, date) so repeated or\n// overlapping exports never duplicate. Survives a full historical backfill.\n//\n// ENV VARS (val editor → environment variables):\n// UPLOAD_TOKEN — sent by the exporter as a Bearer header, or ?token=\n// READ_KEY — gates every read endpoint, travels in the URL\n//\n// EXPORTER SETUP\n// Health Auto Export → Automations → New Automation → REST API\n// URL: https://.web.val.run\n// Header: Authorization: Bearer \n// Format: JSON. Then \"Export Now\" for the full history.\n//\n// READ ENDPOINTS (append &key= to each)\n// /__status counts, date span, last ingest\n// /__metrics every metric held, with range + count\n// /__series?name=step_count&days=30 raw points for one metric\n// /__daily?names=a,b&days=30 several metrics pivoted by day\n// /__workouts?days=90 workout sessions\n// /__requests last 20 raw requests (debugging)\n\nimport { sqlite } from \"https://esm.town/v/std/sqlite\";\nimport { blob } from \"https://esm.town/v/std/blob\";\n\nconst UPLOAD_TOKEN = Deno.env.get(\"UPLOAD_TOKEN\") ??\n \"ShFvNS7rpTki8tqms6JPjYnee5ry-yxHnFdqLvsl-0E\";\nconst READ_KEY = Deno.env.get(\"READ_KEY\") ??\n \"kkD_ejq7nYjQhEzYeMIbD4kTSpb9zRBB_UD3vtoMgWY\";\nconst KEY_LOG = \"health:requests\";\n\nconst json = (data: unknown, status = 200) =>\n new Response(JSON.stringify(data, null, 2), {\n status,\n headers: { \"content-type\": \"application/json; charset=utf-8\" },\n });\n\n// ---------------------------------------------------------------- schema ---\n\nlet ready = false;\nasync function init() {\n if (ready) return;\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS metric_points (\n metric TEXT NOT NULL,\n day TEXT NOT NULL,\n units TEXT,\n point TEXT NOT NULL,\n PRIMARY KEY (metric, day)\n )`);\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS workouts (\n id TEXT PRIMARY KEY,\n name TEXT,\n day TEXT,\n start TEXT,\n body TEXT NOT NULL\n )`);\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS ingest_log (\n at TEXT NOT NULL,\n bytes INTEGER,\n points INTEGER,\n wkts INTEGER\n )`);\n await sqlite.execute(\n `CREATE INDEX IF NOT EXISTS idx_metric_day ON metric_points (metric, day)`,\n );\n ready = true;\n}\n\n// ------------------------------------------------------------- utilities ---\n\n/** HAE dates look like \"2026-08-01 00:00:00 -0400\". Take the calendar day. */\nfunction toDay(value: unknown): string | null {\n if (typeof value !== \"string\") return null;\n const m = value.match(/^(\\d{4}-\\d{2}-\\d{2})/);\n return m ? m[1] : null;\n}\n\n/** Find a usable date on a point regardless of which key the exporter used. */\nfunction pointDay(p: Record): string | null {\n for (const k of [\"date\", \"startDate\", \"start\", \"day\", \"timestamp\"]) {\n const d = toDay(p[k]);\n if (d) return d;\n }\n return null;\n}\n\nfunction daysAgo(n: number): string {\n const d = new Date(Date.now() - n * 86_400_000);\n return d.toISOString().slice(0, 10);\n}\n\nfunction rowsToObjects(res: { columns: string[]; rows: unknown[][] }) {\n return res.rows.map((r) =>\n Object.fromEntries(res.columns.map((c, i) => [c, r[i]]))\n );\n}\n\n/** Insert in chunks — one statement per row is far too slow for a backfill. */\nasync function upsertPoints(\n rows: { metric: string; day: string; units: string; point: string }[],\n) {\n const CHUNK = 100;\n for (let i = 0; i < rows.length; i += CHUNK) {\n const slice = rows.slice(i, i + CHUNK);\n const placeholders = slice.map(() => \"(?, ?, ?, ?)\").join(\", \");\n const args: string[] = [];\n for (const r of slice) args.push(r.metric, r.day, r.units, r.point);\n await sqlite.execute({\n sql: `INSERT INTO metric_points (metric, day, units, point)\n VALUES ${placeholders}\n ON CONFLICT(metric, day) DO UPDATE SET\n point = excluded.point,\n units = excluded.units`,\n args,\n });\n }\n}\n\nasync function logRequest(entry: unknown) {\n let log: unknown[] = [];\n try {\n log = (await blob.getJSON(KEY_LOG)) as unknown[];\n } catch {\n log = [];\n }\n if (!Array.isArray(log)) log = [];\n log.unshift(entry);\n await blob.setJSON(KEY_LOG, log.slice(0, 20));\n}\n\n// ---------------------------------------------------------------- ingest ---\n\nasync function ingest(raw: string) {\n const parsed = JSON.parse(raw);\n const root = parsed?.data ?? parsed;\n\n const pending: {\n metric: string;\n day: string;\n units: string;\n point: string;\n }[] = [];\n let skipped = 0;\n\n for (const metric of root?.metrics ?? []) {\n const name = String(metric?.name ?? \"unknown\");\n const units = String(metric?.units ?? \"\");\n const points = Array.isArray(metric?.data) ? metric.data : [];\n for (const p of points) {\n const day = pointDay(p ?? {});\n if (!day) {\n skipped++;\n continue;\n }\n pending.push({ metric: name, day, units, point: JSON.stringify(p) });\n }\n }\n\n // Later duplicates within one payload win, matching upsert semantics.\n const deduped = new Map();\n for (const r of pending) deduped.set(`${r.metric}\\u0000${r.day}`, r);\n await upsertPoints([...deduped.values()]);\n\n let workoutCount = 0;\n for (const w of root?.workouts ?? []) {\n const start = w?.start ?? w?.startDate ?? null;\n const id = String(\n w?.id ?? w?.uuid ?? `${w?.name ?? \"workout\"}:${start ?? \"\"}`,\n );\n await sqlite.execute({\n sql: `INSERT INTO workouts (id, name, day, start, body)\n VALUES (?, ?, ?, ?, ?)\n ON CONFLICT(id) DO UPDATE SET body = excluded.body`,\n args: [\n id,\n String(w?.name ?? \"\"),\n toDay(start) ?? \"\",\n String(start ?? \"\"),\n JSON.stringify(w),\n ],\n });\n workoutCount++;\n }\n\n await sqlite.execute({\n sql: `INSERT INTO ingest_log (at, bytes, points, wkts) VALUES (?, ?, ?, ?)`,\n args: [new Date().toISOString(), raw.length, deduped.size, workoutCount],\n });\n\n return { points: deduped.size, workouts: workoutCount, skipped };\n}\n\n// ----------------------------------------------------------------- routes ---\n\nexport default async function (req: Request): Promise {\n await init();\n const url = new URL(req.url);\n const path = url.pathname;\n const qs = url.searchParams;\n // Log everything that isn't one of my own read endpoints, so failed\n // probes and rejected posts are both visible.\n if (!path.startsWith(\"/__\")) {\n await logRequest({\n at: new Date().toISOString(),\n method: req.method,\n path,\n query: Object.fromEntries(qs),\n headers: Object.fromEntries(req.headers),\n });\n }\n // ---- Ingest ------------------------------------------------------------\n if (req.method === \"POST\") {\n const header = req.headers.get(\"authorization\") ?? \"\";\n const supplied = header.replace(/^Bearer\\s+/i, \"\").trim() ||\n qs.get(\"token\") || \"\";\n if (!UPLOAD_TOKEN || supplied !== UPLOAD_TOKEN) {\n return json({ error: \"unauthorized\" }, 401);\n }\n\n const raw = await req.text();\n try {\n const result = await ingest(raw);\n await logRequest({\n at: new Date().toISOString(),\n path,\n bytes: raw.length,\n ...result,\n });\n // Always 200 — some exporters abort the whole run on a non-2xx.\n return json({ status: \"ok\", ...result });\n } catch (err) {\n await logRequest({\n at: new Date().toISOString(),\n path,\n bytes: raw.length,\n error: String(err),\n preview: raw.slice(0, 300),\n });\n return json({ status: \"ok\", stored: false, error: String(err) });\n }\n }\n // Exporters often GET the endpoint to validate it before posting.\n // Anything outside /__ answers 200 so that check passes.\n if (!path.startsWith(\"/__\")) {\n return json({ status: \"ok\", ok: true, healthy: true, version: \"1.0.0\" });\n }\n // ---- Reads -------------------------------------------------------------\n if (!READ_KEY || qs.get(\"key\") !== READ_KEY) {\n return json({ error: \"unauthorized\" }, 401);\n }\n\n if (path === \"/__status\") {\n const totals = rowsToObjects(\n await sqlite.execute(\n `SELECT COUNT(*) AS points, COUNT(DISTINCT metric) AS metrics,\n MIN(day) AS earliest, MAX(day) AS latest FROM metric_points`,\n ),\n )[0];\n const wkts = rowsToObjects(\n await sqlite.execute(`SELECT COUNT(*) AS workouts FROM workouts`),\n )[0];\n const last = rowsToObjects(\n await sqlite.execute(`SELECT * FROM ingest_log ORDER BY at DESC LIMIT 5`),\n );\n return json({ ...totals, ...wkts, recentIngests: last });\n }\n\n if (path === \"/__metrics\") {\n return json(\n rowsToObjects(\n await sqlite.execute(\n `SELECT metric, units, COUNT(*) AS days,\n MIN(day) AS earliest, MAX(day) AS latest\n FROM metric_points GROUP BY metric ORDER BY metric`,\n ),\n ),\n );\n }\n\n if (path === \"/__series\") {\n const name = qs.get(\"name\");\n if (!name) return json({ error: \"name parameter required\" }, 400);\n const from = qs.get(\"from\") ?? daysAgo(Number(qs.get(\"days\") ?? 30));\n const to = qs.get(\"to\") ?? \"9999\";\n const rows = rowsToObjects(\n await sqlite.execute({\n sql: `SELECT day, units, point FROM metric_points\n WHERE metric = ? AND day >= ? AND day <= ?\n ORDER BY day`,\n args: [name, from, to],\n }),\n );\n return json({\n metric: name,\n count: rows.length,\n points: rows.map((r) => ({ day: r.day, ...JSON.parse(String(r.point)) })),\n });\n }\n\n if (path === \"/__daily\") {\n const names = (qs.get(\"names\") ?? \"\").split(\",\").map((s) => s.trim())\n .filter(Boolean);\n const from = qs.get(\"from\") ?? daysAgo(Number(qs.get(\"days\") ?? 30));\n const to = qs.get(\"to\") ?? \"9999\";\n const sql = names.length\n ? `SELECT metric, day, point FROM metric_points\n WHERE day >= ? AND day <= ? AND metric IN (${\n names.map(() => \"?\").join(\",\")\n })\n ORDER BY day`\n : `SELECT metric, day, point FROM metric_points\n WHERE day >= ? AND day <= ? ORDER BY day`;\n const rows = rowsToObjects(\n await sqlite.execute({ sql, args: [from, to, ...names] }),\n );\n const byDay: Record> = {};\n for (const r of rows) {\n const day = String(r.day);\n byDay[day] ??= { day };\n const p = JSON.parse(String(r.point));\n byDay[day][String(r.metric)] = p.qty ?? p.Avg ?? p.value ?? p;\n }\n return json(Object.values(byDay));\n }\n\n if (path === \"/__workouts\") {\n const from = qs.get(\"from\") ?? daysAgo(Number(qs.get(\"days\") ?? 90));\n const rows = rowsToObjects(\n await sqlite.execute({\n sql:\n `SELECT id, name, day, body FROM workouts WHERE day >= ? ORDER BY day DESC`,\n args: [from],\n }),\n );\n return json(\n rows.map((r) => ({\n id: r.id,\n day: r.day,\n ...JSON.parse(String(r.body)),\n })),\n );\n }\n\n if (path === \"/__requests\") {\n const log = await blob.getJSON(KEY_LOG).catch(() => []);\n return json(log);\n }\n\n if (path === \"/__wipe\" && qs.get(\"confirm\") === \"yes\") {\n await sqlite.execute(`DELETE FROM metric_points`);\n await sqlite.execute(`DELETE FROM workouts`);\n await sqlite.execute(`DELETE FROM ingest_log`);\n return json({ ok: true, wiped: true });\n }\n\n return json({\n endpoints: [\n \"/__status\",\n \"/__metrics\",\n \"/__series?name=&days=\",\n \"/__daily?names=&days=\",\n \"/__workouts?days=\",\n \"/__requests\",\n \"/__wipe?confirm=yes\",\n ],\n });\n}","deleted","label","children",[],"path",[41],{"_39":40,"_13":41,"_42":43,"_44":-5,"_45":46,"_47":48,"_49":38,"_50":64,"_16":52,"_53":54,"_55":56,"_57":35,"_58":-5,"_61":65},["D",1785730703083],[41],"pulls",0,"branches",1,"forks","envVars",{"_75":77,"_78":67},"connections",{"_75":67,"_76":67},"count","unfilledCount",2,"emptyCount","695e222e-5907-494e-8cf0-b0dafe4c1e20",["D",1785728546244],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","","imageUrl","userId","6f0fba1a-0e90-4aa1-9214-f4bc40b03f51","pinnedFileId","pinPreview","pinMigrated","screenshotVersion","likeCount","orgId","019fc5b5-a55f-7487-9b94-970ed35d1ea2","tursoName","695e222e5907494e8cf0b0dafe4c1e20","tursoHostname","695e222e5907494e8cf0b0dafe4c1e20-val-town.aws-us-east-2.turso.io","tursoMeasuredAt",["D",1789648865183],"pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_11":12,"_137":133},"org",{"_11":12,"_130":131,"_132":133,"_89":90,"_134":135,"_136":35},"branch",{"_16":48,"_13":121,"_39":46,"_122":79,"_123":-5,"_124":-5,"_125":-5,"_126":-5,"_127":-5,"_128":14,"_129":12},"isOwned","main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","displayName","Rishabh Agarwal","avatar","https://lh3.googleusercontent.com/a/ACg8ocIxnxW5Vqb18LHrggnYU3B7VYly3_ka6_Jt9YmaZcXpme4a7vfxOQ=s96-c","tier","free","canRestrictVals","profileImageUrl","adoptOrgId",{"_39":79,"_13":14,"_50":163,"_81":-5,"_82":35,"_83":84,"_85":84,"_86":87,"_88":-5,"_89":90,"_91":43,"_92":38,"_93":-5,"_94":-5,"_95":67,"_96":97,"_98":99,"_100":101,"_102":164,"_104":-5,"_105":106,"_107":106,"_108":109,"_110":109,"_111":109,"_112":106,"_113":106,"_114":165,"_116":166,"_118":167,"_120":35},"tree",[160],[160],{"_66":67,"_68":69,"_70":67,"_71":158,"_73":159},[156],"file","upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},{"_39":40,"_13":41,"_42":43,"_44":-5,"_45":46,"_47":48,"_49":38,"_50":64,"_16":52,"_53":54,"_55":56,"_57":35,"_58":-5,"_61":157},[41],{"_75":77,"_78":67},{"_75":67,"_76":67},{"_39":40,"_13":41,"_42":43,"_44":-5,"_45":46,"_47":48,"_49":38,"_50":51,"_16":52,"_53":54,"_55":56,"_57":35,"_58":-5,"_59":161,"_61":162},[],[41],["D",1785728546244],["D",1789648865183],{"_11":12,"_137":133},{"_11":12,"_130":131,"_132":133,"_89":90,"_134":135,"_136":35},{"_16":48,"_13":121,"_39":46,"_122":79,"_123":-5,"_124":-5,"_125":-5,"_126":-5,"_127":-5,"_128":14,"_129":12},"ctx",{"_114":-5,"_153":201,"_202":203,"_204":205,"_206":35,"_207":35,"_208":35,"_209":38,"_210":-5,"_211":-7,"_212":-7,"_213":67,"_214":35,"_215":35,"_216":-5,"_217":35,"_218":35,"_219":35,"_220":-5},"ENV",{"_172":173,"_174":175,"_176":121,"_177":178,"_179":180,"_181":182,"_183":184,"_185":186,"_187":188,"_189":190,"_191":192,"_193":194,"_195":196,"_197":198,"_199":200},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","RENDER_GIT_COMMIT","c73f21da490985bff19c279eb0e09db24d688e4f","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"]