[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8},"actionData","errors","root",{"_105":106,"_107":108},"routes/embed.x.$handle.$name.$",{"_9":10,"_11":12,"_13":14,"_15":16,"_17":18,"_19":20,"_21":-5},"handle","pchinjr","name","roverwatch-vision-lab","path","index.ts","project",{"_22":45,"_11":12,"_33":46,"_47":-5,"_48":42,"_49":50,"_51":50,"_52":53,"_54":-5,"_55":56,"_57":25,"_58":32,"_59":-5,"_60":-5,"_61":62,"_63":64,"_65":66,"_67":68,"_69":70,"_71":-5,"_72":73,"_74":73,"_75":76,"_77":76,"_78":76,"_79":73,"_80":73,"_81":82,"_83":84,"_85":86,"_87":42},"file",{"_22":23,"_11":14,"_24":25,"_26":-5,"_27":28,"_29":30,"_31":32,"_33":34,"_35":36,"_37":38,"_39":40,"_41":42,"_43":12,"_13":44},"permalink","https://www.val.town/x/pchinjr/roverwatch-vision-lab/code/index.ts","extension","id","926c5749-2a61-40c2-af22-3e021673a323","fileId","01a0495a-b924-761c-aebd-32882f84364c","parentId","branchId","ec5fed3c-97c0-4273-93d2-1fc6dfd46413","branchVersion",57,"latest",true,"createdAt",["D",1788120545715],"version",7,"fileType","http","content","import { parseVal, serveImmutableFile } from \"https://esm.town/v/std/utils/index.ts\";\nimport { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\nimport { Hono } from \"npm:hono\";\nimport { Root } from \"./frontend/root.tsx\";\nimport { defaultDifficulty, presets } from \"./frontend/scenarios.ts\";\nimport { decodeRevision, encodeRevision, verifyBeaconRoundTrip } from \"./frontend/beacon.ts\";\nimport { beaconPixelContract, BEACON_SCHEMA_VERSION } from \"./frontend/beaconContract.ts\";\n\nconst app = new Hono();\nconst VISION_LAB_VERSION = \"vision-lab-latency-v1\";\nconst POLL_INTERVALS = [100, 250, 500];\nconst TRANSITION_INTERVALS = [250, 500, 1000, 2000];\n\nawait sqlite.execute(\"CREATE TABLE IF NOT EXISTS vision_lab_state (id INTEGER PRIMARY KEY CHECK (id = 1), payload TEXT NOT NULL, revision INTEGER NOT NULL DEFAULT 1, updated_at TEXT NOT NULL)\");\nawait sqlite.execute(\"CREATE TABLE IF NOT EXISTS vision_lab_transitions (revision INTEGER PRIMARY KEY, scenario_id TEXT NOT NULL, step INTEGER NOT NULL, scheduled_at TEXT NOT NULL, published_at TEXT NOT NULL, expected_json TEXT NOT NULL, state_json TEXT NOT NULL)\");\nawait sqlite.execute(\"CREATE INDEX IF NOT EXISTS idx_vision_lab_transitions_published_at ON vision_lab_transitions(published_at)\");\nawait sqlite.execute(\"CREATE TABLE IF NOT EXISTS vision_lab_observations (id INTEGER PRIMARY KEY AUTOINCREMENT, revision INTEGER NOT NULL, observer_id TEXT NOT NULL, observed_at TEXT NOT NULL, received_at TEXT NOT NULL)\");\nawait sqlite.execute(\"CREATE TABLE IF NOT EXISTS vision_lab_latency_sessions (session_id TEXT PRIMARY KEY, started_at TEXT NOT NULL, ended_at TEXT, start_revision INTEGER NOT NULL, end_revision INTEGER, configuration_json TEXT NOT NULL, vision_lab_version TEXT NOT NULL)\");\n\nasync function addObservationColumn(definition: string) {\n try {\n await sqlite.execute(\"ALTER TABLE vision_lab_observations ADD COLUMN \" + definition);\n } catch (error) {\n if (!String(error).toLowerCase().includes(\"duplicate column\")) throw error;\n }\n}\nawait addObservationColumn(\"client_received_at TEXT\");\nawait addObservationColumn(\"rendered_at TEXT\");\nawait addObservationColumn(\"poll_duration_ms REAL\");\nawait addObservationColumn(\"poll_interval_ms INTEGER\");\nawait addObservationColumn(\"route TEXT\");\nawait addObservationColumn(\"session_id TEXT\");\nawait sqlite.execute(\"CREATE INDEX IF NOT EXISTS idx_vision_lab_observations_session ON vision_lab_observations(session_id, revision)\");\n\nconst now = new Date().toISOString();\nconst initial = { scenario: presets[0], difficulty: defaultDifficulty, step: 0, scheduledAt: now, publishedAt: now, revision: 1 };\nawait sqlite.execute({ sql: \"INSERT OR IGNORE INTO vision_lab_state (id,payload,revision,updated_at) VALUES (1,?,?,?)\", args: [JSON.stringify(initial), 1, now] });\n\nasync function readState() {\n const result = await sqlite.execute(\"SELECT payload, revision, updated_at FROM vision_lab_state WHERE id = 1\");\n const row = result.rows[0] as Record;\n const state = JSON.parse(String(row.payload));\n return { ...state, scheduledAt: state.scheduledAt || state.startedAt || row.updated_at, publishedAt: state.publishedAt || row.updated_at, revision: Number(row.revision), updatedAt: row.updated_at };\n}\n\nconst bootState = await readState();\nawait sqlite.execute({\n sql: \"INSERT OR IGNORE INTO vision_lab_transitions (revision,scenario_id,step,scheduled_at,published_at,expected_json,state_json) VALUES (?,?,?,?,?,?,?)\",\n args: [Number(bootState.revision), String(bootState.scenario.id), Number(bootState.step || 0), String(bootState.scheduledAt), String(bootState.publishedAt), JSON.stringify(bootState.scenario.expectedResult), JSON.stringify(bootState)],\n});\n\nfunction transitionFromRow(row: Record) {\n return { revision: Number(row.revision), scenarioId: String(row.scenario_id), step: Number(row.step), scheduledAt: String(row.scheduled_at), publishedAt: String(row.published_at), expected: JSON.parse(String(row.expected_json)), state: JSON.parse(String(row.state_json)) };\n}\nfunction observationFromRow(row: Record) {\n return {\n id: Number(row.id), revision: Number(row.revision), observerId: String(row.observer_id),\n observedAt: String(row.observed_at), clientReceivedAt: row.client_received_at ? String(row.client_received_at) : null,\n renderedAt: row.rendered_at ? String(row.rendered_at) : null, receivedAt: String(row.received_at),\n pollDurationMs: row.poll_duration_ms == null ? null : Number(row.poll_duration_ms),\n pollIntervalMs: row.poll_interval_ms == null ? null : Number(row.poll_interval_ms),\n route: row.route ? String(row.route) : null, sessionId: row.session_id ? String(row.session_id) : null,\n };\n}\nfunction validDate(value: unknown) {\n return typeof value === \"string\" && !Number.isNaN(Date.parse(value));\n}\n\napp.get(\"/\", (c) => c.html(Root()));\napp.get(\"/test\", (c) => c.html(Root()));\napp.get(\"/latency\", (c) => c.html(Root()));\napp.get(\"/__immutable/*\", (c) => serveImmutableFile(c.req.path));\napp.get(\"/source\", (c) => c.redirect(parseVal().links.self.val));\n\napp.get(\"/api/state\", async (c) => c.json(await readState()));\napp.get(\"/current.json\", async (c) => c.json(await readState()));\napp.get(\"/api/time\", (c) => {\n const serverTime = new Date();\n return c.json({ serverTime: serverTime.toISOString(), unixMs: serverTime.getTime() });\n});\napp.get(\"/api/beacon-contract\", (c) => c.json(beaconPixelContract));\napp.get(\"/api/beacon/:revision\", (c) => {\n const revision = Number(c.req.param(\"revision\"));\n if (!Number.isInteger(revision) || revision < 0 || revision > 0xffffffff) return c.json({ error: \"revision must be an unsigned 32-bit integer\" }, 400);\n const matrix = encodeRevision(revision);\n return c.json({ revision, matrix, decodedRevision: decodeRevision(matrix), selfTestPassed: verifyBeaconRoundTrip() });\n});\n\napp.get(\"/api/history\", async (c) => {\n const sinceRevision = Math.max(0, Number(c.req.query(\"sinceRevision\") || 0));\n const limit = Math.min(1000, Math.max(1, Number(c.req.query(\"limit\") || 200)));\n const result = await sqlite.execute({ sql: \"SELECT revision,scenario_id,step,scheduled_at,published_at,expected_json,state_json FROM vision_lab_transitions WHERE revision > ? ORDER BY revision ASC LIMIT ?\", args: [sinceRevision, limit] });\n const transitions = result.rows.map((row) => transitionFromRow(row as Record));\n return c.json({ groundTruthOnly: true, sinceRevision, count: transitions.length, transitions });\n});\n\napp.get(\"/api/state-at\", async (c) => {\n const at = c.req.query(\"at\");\n if (!at || Number.isNaN(Date.parse(at))) return c.json({ error: \"Valid ISO-8601 at query parameter required\" }, 400);\n const result = await sqlite.execute({ sql: \"SELECT revision,scenario_id,step,scheduled_at,published_at,expected_json,state_json FROM vision_lab_transitions WHERE published_at <= ? ORDER BY published_at DESC, revision DESC LIMIT 1\", args: [new Date(at).toISOString()] });\n if (!result.rows.length) return c.json({ error: \"No ground-truth state had been published at that time\" }, 404);\n return c.json({ groundTruthOnly: true, capturedAt: new Date(at).toISOString(), transition: transitionFromRow(result.rows[0] as Record) });\n});\n\napp.get(\"/api/observations\", async (c) => {\n const revision = Math.max(0, Number(c.req.query(\"revision\") || 0));\n const limit = Math.min(1000, Math.max(1, Number(c.req.query(\"limit\") || 200)));\n const sessionId = c.req.query(\"sessionId\");\n const route = c.req.query(\"route\");\n const clauses = [\"revision >= ?\"];\n const args: (string | number)[] = [revision];\n if (sessionId) { clauses.push(\"session_id = ?\"); args.push(sessionId); }\n if (route) { clauses.push(\"route = ?\"); args.push(route); }\n args.push(limit);\n const result = await sqlite.execute({\n sql: \"SELECT id,revision,observer_id,observed_at,client_received_at,rendered_at,received_at,poll_duration_ms,poll_interval_ms,route,session_id FROM vision_lab_observations WHERE \" + clauses.join(\" AND \") + \" ORDER BY id DESC LIMIT ?\",\n args,\n });\n return c.json({ groundTruth: false, count: result.rows.length, observations: result.rows.map((row) => observationFromRow(row as Record)) });\n});\n\napp.post(\"/api/state\", async (c) => {\n const body = await c.req.json();\n if (!body?.scenario?.id || !body?.scenario?.visualState || !body?.scenario?.expectedResult) return c.json({ error: \"Invalid scenario payload\" }, 400);\n const current = await readState();\n const publishedAt = new Date().toISOString();\n const scheduledAt = validDate(body.scheduledAt) ? new Date(body.scheduledAt).toISOString() : publishedAt;\n const next = { scenario: body.scenario, difficulty: body.difficulty || defaultDifficulty, step: Number(body.step || 0), scheduledAt, publishedAt, revision: Number(current.revision) + 1 };\n const encoded = JSON.stringify(next);\n if (encoded.length > 100_000) return c.json({ error: \"Payload too large\" }, 413);\n await sqlite.batch([\n { sql: \"INSERT INTO vision_lab_transitions (revision,scenario_id,step,scheduled_at,published_at,expected_json,state_json) VALUES (?,?,?,?,?,?,?)\", args: [next.revision, next.scenario.id, next.step, scheduledAt, publishedAt, JSON.stringify(next.scenario.expectedResult), encoded] },\n { sql: \"UPDATE vision_lab_state SET payload=?, revision=?, updated_at=? WHERE id=1\", args: [encoded, next.revision, publishedAt] },\n ]);\n return c.json(next);\n});\n\napp.post(\"/api/observations\", async (c) => {\n const body = await c.req.json();\n const clientReceivedAt = body?.clientReceivedAt || body?.observedAt;\n const renderedAt = body?.renderedAt || body?.observedAt;\n const observedAt = body?.observedAt || renderedAt;\n if (!Number.isInteger(body?.revision) || !body?.observerId || !validDate(clientReceivedAt) || !validDate(renderedAt) || !validDate(observedAt)) {\n return c.json({ error: \"revision, observerId, and valid clientReceivedAt/renderedAt (or observedAt) are required\" }, 400);\n }\n const receivedAt = new Date().toISOString();\n await sqlite.execute({\n sql: \"INSERT INTO vision_lab_observations (revision,observer_id,observed_at,received_at,client_received_at,rendered_at,poll_duration_ms,poll_interval_ms,route,session_id) VALUES (?,?,?,?,?,?,?,?,?,?)\",\n args: [\n body.revision, String(body.observerId).slice(0, 100), new Date(observedAt).toISOString(), receivedAt,\n new Date(clientReceivedAt).toISOString(), new Date(renderedAt).toISOString(),\n Number.isFinite(Number(body.pollDurationMs)) ? Number(body.pollDurationMs) : null,\n POLL_INTERVALS.includes(Number(body.pollIntervalMs)) ? Number(body.pollIntervalMs) : null,\n body.route ? String(body.route).slice(0, 100) : null,\n body.sessionId ? String(body.sessionId).slice(0, 100) : null,\n ],\n });\n return c.json({ accepted: true, groundTruth: false, revision: body.revision, clientReceivedAt: new Date(clientReceivedAt).toISOString(), renderedAt: new Date(renderedAt).toISOString(), receivedAt }, 201);\n});\n\napp.post(\"/api/latency-sessions/start\", async (c) => {\n const body = await c.req.json();\n const pollIntervalMs = Number(body?.pollIntervalMs);\n const transitionIntervalMs = Number(body?.transitionIntervalMs);\n const count = Number(body?.count);\n if (!POLL_INTERVALS.includes(pollIntervalMs) || !TRANSITION_INTERVALS.includes(transitionIntervalMs) || !Number.isInteger(count) || count < 1 || count > 100) {\n return c.json({ error: \"pollIntervalMs, transitionIntervalMs, and count are invalid\" }, 400);\n }\n const current = await readState();\n const sessionId = crypto.randomUUID();\n const startedAt = new Date().toISOString();\n const configuration = { pollIntervalMs, transitionIntervalMs, count };\n await sqlite.execute({\n sql: \"INSERT INTO vision_lab_latency_sessions (session_id,started_at,start_revision,configuration_json,vision_lab_version) VALUES (?,?,?,?,?)\",\n args: [sessionId, startedAt, Number(current.revision), JSON.stringify(configuration), VISION_LAB_VERSION],\n });\n return c.json({ session: { sessionId, startedAt, startingRevision: Number(current.revision), configuration, visionLabVersion: VISION_LAB_VERSION } }, 201);\n});\n\napp.post(\"/api/latency-sessions/:id/stop\", async (c) => {\n const sessionId = c.req.param(\"id\");\n const existing = await sqlite.execute({ sql: \"SELECT session_id FROM vision_lab_latency_sessions WHERE session_id = ?\", args: [sessionId] });\n if (!existing.rows.length) return c.json({ error: \"Latency session not found\" }, 404);\n const current = await readState();\n const endedAt = new Date().toISOString();\n await sqlite.execute({ sql: \"UPDATE vision_lab_latency_sessions SET ended_at = COALESCE(ended_at, ?), end_revision = COALESCE(end_revision, ?) WHERE session_id = ?\", args: [endedAt, Number(current.revision), sessionId] });\n return c.json({ sessionId, endedAt, endingRevision: Number(current.revision) });\n});\n\napp.get(\"/api/latency-sessions/:id/export\", async (c) => {\n const sessionId = c.req.param(\"id\");\n const sessionResult = await sqlite.execute({ sql: \"SELECT session_id,started_at,ended_at,start_revision,end_revision,configuration_json,vision_lab_version FROM vision_lab_latency_sessions WHERE session_id = ?\", args: [sessionId] });\n if (!sessionResult.rows.length) return c.json({ error: \"Latency session not found\" }, 404);\n const row = sessionResult.rows[0] as Record;\n const current = await readState();\n const endRevision = row.end_revision == null ? Number(current.revision) : Number(row.end_revision);\n const transitionsResult = await sqlite.execute({\n sql: \"SELECT revision,scenario_id,step,scheduled_at,published_at,expected_json,state_json FROM vision_lab_transitions WHERE revision > ? AND revision <= ? ORDER BY revision ASC\",\n args: [Number(row.start_revision), endRevision],\n });\n const observationsResult = await sqlite.execute({\n sql: \"SELECT id,revision,observer_id,observed_at,client_received_at,rendered_at,received_at,poll_duration_ms,poll_interval_ms,route,session_id FROM vision_lab_observations WHERE session_id = ? ORDER BY id ASC\",\n args: [sessionId],\n });\n return c.json({\n schemaVersion: VISION_LAB_VERSION, beaconSchemaVersion: BEACON_SCHEMA_VERSION, sessionId, visionLabVersion: String(row.vision_lab_version),\n startedAt: String(row.started_at), endedAt: row.ended_at ? String(row.ended_at) : null,\n startingRevision: Number(row.start_revision), endingRevision: endRevision,\n configuration: JSON.parse(String(row.configuration_json)),\n groundTruth: { authoritative: true, transitions: transitionsResult.rows.map((item) => transitionFromRow(item as Record)) },\n observations: { authoritative: false, records: observationsResult.rows.map((item) => observationFromRow(item as Record)) },\n });\n});\n\napp.onError((err) => Promise.reject(err));\nexport default app.fetch;","deleted",false,"label",[14],"546ce605-1508-4081-a1fc-e50474041c15",["D",1787937077281],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","Deterministic computer vision test harness","imageUrl","userId","40e69d1a-3254-4858-920b-7b1449761575","pinnedFileId","pinPreview","pinMigrated","screenshotVersion","likeCount",0,"orgId","54bae3d1-8223-41e5-b22d-81eb28a263c7","tursoName","546ce60515084081a1fce50474041c15","tursoHostname","546ce60515084081a1fce50474041c15-val-town.aws-us-east-2.turso.io","tursoMeasuredAt",["D",1789501263826],"pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_9":10,"_104":100},"org",{"_9":10,"_98":-5,"_99":100,"_55":56,"_101":102,"_103":42},"branch",{"_35":88,"_11":89,"_22":28,"_90":45,"_91":-5,"_92":-5,"_93":-5,"_94":-5,"_95":-5,"_96":12,"_97":10},"isOwned",76,"main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","displayName","avatar","https://images.clerk.dev/oauth_github/img_2OaSpooJk6yZ5KFqyjtIVA4z3SH.jpeg","tier","free","canRestrictVals","profileImageUrl","ctx",{"_81":-5,"_138":139,"_140":141,"_142":143,"_144":42,"_145":42,"_146":42,"_147":32,"_148":-5,"_149":-7,"_150":-7,"_151":62,"_152":42,"_153":42,"_154":-5,"_155":42,"_156":42,"_157":42,"_158":-5},"ENV",{"_109":110,"_111":112,"_113":89,"_114":115,"_116":117,"_118":119,"_120":121,"_122":123,"_124":125,"_126":127,"_128":129,"_130":131,"_132":133,"_134":135,"_136":137},"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","orgs",[],"preferencesKeybindings","default","preferencesTheme","light","preferencesFixers","preferencesCopilot","preferencesSelectionAi","preferencesCloseBrackets","preferencesChatPanelState","preferencesDprint","preferencesDenofmt","notificationCount","flagDenols","isBusinessOrgMember","businessOrgHandle","isBusinessOrgAdmin","isHigherTownieTier","navCollapsed","currentOrgId"]