[{"_1":2,"_185":-5,"_186":-5},"loaderData",{"_3":4,"_96":97},"root",{"_5":6,"_37":38,"_69":70},"ctx",{"_7":8,"_23":-5,"_24":25,"_26":27,"_28":20,"_29":20,"_30":20,"_31":-5,"_32":33,"_34":20,"_35":20,"_36":20},"auth",{"_9":-5,"_10":-5,"_11":-5,"_12":-5,"_13":-5,"_14":-5,"_15":-5,"_16":-5,"_17":-5,"_18":-5,"_19":20,"_21":22},"sessionClaims","sessionId","sessionStatus","userId","actor","orgId","orgRole","orgSlug","orgPermissions","factorVerificationAge","isAuthenticated",false,"tokenType","session_token","user","preferencesKeybindings","default","preferencesTheme","light","preferencesFixers","preferencesCopilot","preferencesSelectionAi","preferencesChatPanelState","notificationCount",0,"flagDenols","isBusinessOrgMember","isHigherTownieTier","ENV",{"_39":40,"_41":42,"_43":44,"_45":46,"_47":48,"_49":50,"_51":52,"_53":54,"_55":56,"_57":58,"_59":60,"_61":62,"_63":64,"_65":66,"_67":68},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","VAL_RUNTIME_NAME","prod","RENDER_GIT_COMMIT","efeea19332d9bfe7de1049656877be9cb817c45f","RENDER_GIT_BRANCH","main","CLERK_PUBLISHABLE_KEY","pk_live_Y2xlcmsudmFsLnRvd24k","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","API_URL","https://api.val.town","clerkState",{"_71":72},"__internal_clerk_state",{"_73":74,"_75":48,"_76":77,"_78":77,"_79":20,"_80":77,"_81":77,"_82":77,"_83":77,"_84":85,"_94":20,"_95":20},"__clerk_ssr_state",{"_21":22,"_9":-5,"_10":-5,"_11":-5,"_12":-5,"_13":-5,"_14":-5,"_15":-5,"_16":-5,"_17":-5,"_18":-5,"_19":20},"__publishableKey","__proxyUrl","","__domain","__isSatellite","__signInUrl","__signUpUrl","__afterSignInUrl","__afterSignUpUrl","__clerk_debug",{"_86":20,"_19":20,"_87":77,"_88":89,"_90":77,"_91":48,"_92":20,"_93":77},"isSignedIn","proxyUrl","reason","session-token-and-uat-missing","message","publishableKey","isSatellite","domain","__telemetryDisabled","__telemetryDebug","routes/embed.x.$handle.$name.$",{"_98":99,"_100":101,"_102":103,"_104":105,"_162":163,"_182":183,"_184":-5},"handle","dcm31","name","yesno","path","ingest.ts","project",{"_106":107,"_100":101,"_108":109,"_110":-5,"_111":20,"_112":113,"_114":115,"_116":-5,"_12":117,"_118":-5,"_119":20,"_120":-5,"_121":-5,"_122":33,"_14":123,"_124":125,"_126":127,"_128":129,"_130":-5,"_131":132,"_133":132,"_134":135,"_136":135,"_137":135,"_138":132,"_139":132,"_23":140,"_143":144,"_148":149,"_161":20},"id","4cb49016-ffb1-11f0-91be-42dde27851f2","createdAt",["D",1769979740966],"deletedAt","legacyEnvVars","privacy","unlisted","description","Yes/No question prototype","imageUrl","9319c175-2593-4f88-ba21-04f2ef7b1c28","pinnedFileId","pinPreview","pinMigrated","screenshotVersion","likeCount","d663a026-6449-42f6-9156-1d4a2d64d38c","tursoName","4cb49016ffb111f091be42dde27851f2","tursoHostname","4cb49016ffb111f091be42dde27851f2-val-town.aws-us-east-2.turso.io","tursoMeasuredAt",["D",1776208856590],"pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm",{"_98":99,"_141":142},"profileImageUrl","https://imagedelivery.net/iHX6Ovru0O7AjmyT5yZRoA/3e904faa-3764-4629-c475-f561a49b0000/square512","org",{"_98":99,"_145":142,"_12":117,"_146":147},"avatar","tier","pro","branch",{"_150":151,"_100":46,"_106":152,"_153":107,"_154":-5,"_155":-5,"_156":-5,"_157":-5,"_158":-5,"_159":101,"_160":99},"version",30,"4cb4e21e-ffb1-11f0-91be-42dde27851f2","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","isOwned","file",{"_106":164,"_100":103,"_165":166,"_167":-5,"_168":152,"_169":170,"_171":172,"_108":173,"_150":174,"_175":176,"_177":178,"_179":20,"_180":-5,"_102":181},"250c59cc-1064-11f1-998f-42dde27851f2","fileId","9264a700-1063-11f1-a3b7-42dde27851f2","parentId","branchId","branchVersion",24,"latest",true,["D",1771815772937],1,"fileType","script","content","/**\n * Raw data ingestion + metric extraction.\n *\n * POST /ingest — accept anything, store it, extract what we can.\n * GET /metrics — latest extracted values.\n * GET /metrics/:key — single metric (e.g., /metrics/vo2max).\n * GET /log — raw chronological log.\n *\n * Designed to be hit from Apple Shortcuts with minimal formatting.\n * The endpoint is forgiving: JSON, form data, plain text, query params — all fine.\n */\n\nimport { blob } from \"https://esm.town/v/std/blob\";\n\n// ── Types ──────────────────────────────────────────────────\n\nexport interface LogEntry {\n timestamp: number;\n iso: string;\n raw: string; // original payload as-is\n contentType: string;\n extracted: Record; // parsed metrics\n}\n\nexport interface MetricSnapshot {\n value: number | string;\n timestamp: number;\n iso: string;\n}\n\n// ── Storage ────────────────────────────────────────────────\n\nconst LOG_KEY = \"ingest_log_v1\";\nconst METRICS_KEY = \"ingest_metrics_v1\";\n\nexport async function getLog(): Promise {\n try { return await blob.getJSON(LOG_KEY) as LogEntry[] ?? []; }\n catch { return []; }\n}\n\nasync function appendLog(entry: LogEntry): Promise {\n const log = await getLog();\n log.push(entry);\n // Keep last 500 entries\n if (log.length > 500) log.splice(0, log.length - 500);\n await blob.setJSON(LOG_KEY, log);\n}\n\nexport async function getMetrics(): Promise> {\n try { return await blob.getJSON(METRICS_KEY) as Record ?? {}; }\n catch { return {}; }\n}\n\nasync function updateMetrics(extracted: Record, timestamp: number, iso: string): Promise {\n const metrics = await getMetrics();\n for (const [key, value] of Object.entries(extracted)) {\n metrics[key] = { value, timestamp, iso };\n }\n await blob.setJSON(METRICS_KEY, metrics);\n}\n\n// ── Extraction ─────────────────────────────────────────────\n\n/**\n * Try to extract known metrics from raw text.\n * Deliberately loose matching — Apple Shortcuts sends weird stuff.\n */\nexport function extractMetrics(raw: string): Record {\n const extracted: Record = {};\n\n // Try JSON first — Apple Shortcuts often sends structured data\n try {\n const json = JSON.parse(raw);\n if (typeof json === \"object\" && json !== null) {\n for (const [key, val] of Object.entries(json)) {\n const normalized = key.toLowerCase().replace(/[\\s_-]/g, \"\");\n if (typeof val === \"number\") {\n // Map common keys\n if (normalized === \"vo2max\" || normalized === \"vo2\") extracted.vo2max = val;\n else extracted[normalized] = val;\n } else if (typeof val === \"string\") {\n const num = parseFloat(val);\n if (!isNaN(num)) {\n if (normalized === \"vo2max\" || normalized === \"vo2\") extracted.vo2max = num;\n else extracted[normalized] = num;\n } else {\n extracted[normalized] = val;\n }\n }\n }\n if (Object.keys(extracted).length > 0) return extracted;\n }\n } catch { /* not JSON, try regex */ }\n\n const text = raw.toLowerCase();\n\n // VO2 max: look for a number near \"vo2\" or \"v02\" or \"vo2max\"\n const vo2Patterns = [\n /vo2\\s*max\\s*[:\\-=]?\\s*([\\d.]+)/i,\n /v02\\s*max\\s*[:\\-=]?\\s*([\\d.]+)/i,\n /vo2\\s*[:\\-=]?\\s*([\\d.]+)/i,\n /([\\d.]+)\\s*vo2/i,\n /([\\d.]+)\\s*v02/i,\n // If the whole string is just a number and we're expecting vo2max\n // (context from the endpoint path will help here)\n ];\n\n for (const pattern of vo2Patterns) {\n const match = raw.match(pattern);\n if (match) {\n const val = parseFloat(match[1]);\n if (val > 10 && val < 100) { // sane VO2 max range\n extracted.vo2max = val;\n break;\n }\n }\n }\n\n // If we got nothing but the whole thing is just a number,\n // stash it as \"unknown_number\" — caller can assign meaning via path\n if (Object.keys(extracted).length === 0) {\n const numMatch = raw.trim().match(/^[\\d.]+$/);\n if (numMatch) {\n extracted._number = parseFloat(numMatch[0]);\n }\n }\n\n return extracted;\n}\n\n// ── Ingest handler ─────────────────────────────────────────\n\n/**\n * Process an incoming request. Returns the log entry created.\n * Called from main.ts route handlers.\n */\nexport async function ingest(req: Request, metricHint?: string): Promise {\n const contentType = req.headers.get(\"content-type\") || \"unknown\";\n let raw = \"\";\n\n try {\n raw = await req.text();\n } catch {\n raw = \"\";\n }\n\n // Also grab query params in case Shortcuts sends data that way\n const url = new URL(req.url);\n const queryData = Object.fromEntries(url.searchParams.entries());\n if (Object.keys(queryData).length > 0 && !raw) {\n raw = JSON.stringify(queryData);\n } else if (Object.keys(queryData).length > 0) {\n raw = raw + \" | query: \" + JSON.stringify(queryData);\n }\n\n const now = new Date();\n const extracted = extractMetrics(raw);\n\n // If a metric hint was provided (e.g., from /ingest/vo2max path)\n // and we found an unassigned number, assign it\n if (metricHint && extracted._number !== undefined && !extracted[metricHint]) {\n extracted[metricHint] = extracted._number;\n delete extracted._number;\n }\n\n const entry: LogEntry = {\n timestamp: now.getTime(),\n iso: now.toISOString(),\n raw,\n contentType,\n extracted,\n };\n\n await appendLog(entry);\n\n if (Object.keys(extracted).length > 0) {\n await updateMetrics(extracted, entry.timestamp, entry.iso);\n }\n\n console.log(`[ingest] raw=\"${raw.slice(0, 100)}\" extracted=`, extracted);\n return entry;\n}\n","deleted","label",[103],"permalink","https://www.val.town/x/dcm31/yesno/code/ingest.ts","extension","actionData","errors"]