[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8},"actionData","errors","root",{"_106":107,"_108":109},"routes/embed.x.$handle.$name.$",{"_9":10,"_11":12,"_13":14,"_15":16,"_17":18,"_19":20,"_21":-5},"handle","mcpconformance","name","mcp-client-conformance","path","examples/hosted/valtown-store.ts","project",{"_22":49,"_11":12,"_35":50,"_51":-5,"_52":44,"_53":54,"_55":54,"_56":-5,"_57":-5,"_58":59,"_60":61,"_62":34,"_63":-5,"_64":-5,"_65":66,"_67":68,"_69":-5,"_70":-5,"_71":-5,"_72":-5,"_73":74,"_75":74,"_76":77,"_78":77,"_79":77,"_80":74,"_81":74,"_82":83,"_84":85,"_86":87,"_88":44},"file",{"_22":23,"_11":24,"_25":26,"_27":28,"_29":30,"_31":32,"_33":34,"_35":36,"_37":38,"_39":40,"_41":42,"_43":44,"_45":-5,"_13":46},"permalink","https://www.val.town/x/mcpconformance/mcp-client-conformance/code/examples/hosted/valtown-store.ts","extension","id","4368020e-4062-4213-9d77-e9a80e774d5b","valtown-store.ts","fileId","d1ffa5b6-ad13-11f1-8f33-1607ee4eb77e","parentId","33e15d6c-9b64-4c7e-ad30-c57b58f95711","branchId","fdc11199-683b-41f1-a3c5-d5ac53972f86","branchVersion",384,"latest",true,"createdAt",["D",1789379122160],"version",6,"fileType","script","content","/**\n * RunStore backed by val.town's per-account SQLite (REST API).\n *\n * val.town injects an API token into every val as the `valtown` env var; the\n * SQLite API is `POST /v1/sqlite/execute {statement:{sql,args}}`. Two tables\n * for runs, created the first time a statement on them fails (so a cold\n * isolate does not spend two round trips making sure), and a third for\n * frozen reports, created the first time an isolate touches one. A cell's\n * attempts and traffic have a table each, created the first time a\n * statement on it fails. Old runs (with their attempts and traffic) are\n * swept on new-run creation and old snapshots on new-snapshot creation,\n * throttled per isolate, so the database stays bounded without a cron.\n */\n\nimport type { ConformanceCheck } from '../../src/types.ts';\nimport {\n CHALLENGE_RETENTION_MS,\n type RunStore,\n type SnapshotInfo,\n type StoreRetention\n} from '../../src/hosted/store.ts';\nimport { TRAFFIC_CELL_BYTES, type TrafficRow } from '../../src/hosted/traffic.ts';\n\nconst API = 'https://api.val.town/v1/sqlite/execute';\n\n/** Default run retention (`CONFORMANCE_RUN_RETENTION_MS`): 6 hours. */\nexport const DEFAULT_RUN_RETENTION_MS = 6 * 3600_000;\n/**\n * Default snapshot retention (`CONFORMANCE_SNAPSHOT_RETENTION_MS`): 30 days,\n * long enough for a permalink pasted into an issue to stay useful.\n */\nexport const DEFAULT_SNAPSHOT_RETENTION_MS = 30 * 24 * 3600_000;\n\nexport interface SqliteRunStoreOptions {\n token?: string;\n /**\n * A cell's rows are swept this long after its first request. Default\n * DEFAULT_RUN_RETENTION_MS.\n */\n retentionMs?: number;\n /**\n * Snapshots older than this are swept. Default\n * DEFAULT_SNAPSHOT_RETENTION_MS.\n */\n snapshotRetentionMs?: number;\n /** Cap on checks persisted per (run, writer). Default 1000. */\n maxChecks?: number;\n}\n\ntype Row = unknown[];\n\nexport class SqliteRunStore implements RunStore {\n private readonly token: string;\n private readonly retentionMs: number;\n private readonly snapshotRetentionMs: number;\n private readonly maxChecks: number;\n private ready: Promise | undefined;\n private snapshotsReady: Promise | undefined;\n private lastSweep = 0;\n private lastSnapshotSweep = 0;\n private lastChallengeSweep = 0;\n\n constructor(opts: SqliteRunStoreOptions = {}) {\n const token = opts.token ?? process.env.valtown;\n if (!token)\n throw new Error('SqliteRunStore: no val.town token (env valtown)');\n this.token = token;\n this.retentionMs =\n opts.retentionMs ??\n Number(\n process.env.CONFORMANCE_RUN_RETENTION_MS ?? DEFAULT_RUN_RETENTION_MS\n );\n this.snapshotRetentionMs =\n opts.snapshotRetentionMs ??\n Number(\n process.env.CONFORMANCE_SNAPSHOT_RETENTION_MS ??\n DEFAULT_SNAPSHOT_RETENTION_MS\n );\n this.maxChecks = opts.maxChecks ?? 1000;\n }\n\n /** What the landing page tells people, from the values in force. */\n get retention(): StoreRetention {\n return { runMs: this.retentionMs, snapshotMs: this.snapshotRetentionMs };\n }\n\n private async exec(sql: string, args: unknown[] = []): Promise {\n const res = await fetch(API, {\n method: 'POST',\n headers: {\n Authorization: `Bearer ${this.token}`,\n 'Content-Type': 'application/json'\n },\n body: JSON.stringify({ statement: { sql, args } })\n });\n if (!res.ok) {\n throw new Error(\n `sqlite ${res.status}: ${(await res.text()).slice(0, 200)}`\n );\n }\n const body = (await res.json()) as { rows?: Row[] };\n return body.rows ?? [];\n }\n\n /**\n * A statement on the runs tables. They exist but for a fresh account, so\n * it is sent at once; only if it fails are the tables created and the\n * statement sent again. A cold isolate's first write is one round trip,\n * not three.\n */\n private async execRuns(sql: string, args: unknown[] = []): Promise {\n if (this.ready) {\n await this.ready;\n return this.exec(sql, args);\n }\n try {\n return await this.exec(sql, args);\n } catch {\n await this.init();\n return this.exec(sql, args);\n }\n }\n\n private init(): Promise {\n this.ready ??= (async () => {\n await this.exec(\n `CREATE TABLE IF NOT EXISTS hosted_runs_v2 (\n id TEXT PRIMARY KEY, scenario TEXT NOT NULL, created_at INTEGER NOT NULL)`\n );\n await this.exec(\n `CREATE TABLE IF NOT EXISTS hosted_checks_v2 (\n run_id TEXT NOT NULL, writer TEXT NOT NULL, checks TEXT NOT NULL,\n updated_at INTEGER NOT NULL, PRIMARY KEY (run_id, writer))`\n );\n })().catch((e) => {\n this.ready = undefined;\n throw e;\n });\n return this.ready;\n }\n\n async saveRun(id: string, scenarioName: string): Promise {\n await this.execRuns(\n `INSERT INTO hosted_runs_v2 (id, scenario, created_at) VALUES (?, ?, ?)\n ON CONFLICT(id) DO UPDATE SET scenario = excluded.scenario`,\n [id, scenarioName, Date.now()]\n );\n void this.sweep().catch(() => {});\n }\n\n async loadRun(id: string): Promise {\n const rows = await this.execRuns(\n `SELECT scenario FROM hosted_runs_v2 WHERE id = ?`,\n [id]\n );\n return rows[0]?.[0] as string | undefined;\n }\n\n async listRuns(\n prefix: string\n ): Promise> {\n // LIKE treats % and _ as wildcards; escape them (and the escape char) so\n // the prefix matches literally.\n const like = prefix.replace(/[\\\\%_]/g, (c) => `\\\\${c}`) + '%';\n const rows = await this.execRuns(\n `SELECT id, scenario FROM hosted_runs_v2 WHERE id LIKE ? ESCAPE '\\\\'`,\n [like]\n );\n return rows.map(([id, scenario]) => ({\n id: id as string,\n scenarioName: scenario as string\n }));\n }\n\n async saveChecks(\n id: string,\n writer: string,\n checks: ConformanceCheck[]\n ): Promise {\n await this.execRuns(\n `INSERT INTO hosted_checks_v2 (run_id, writer, checks, updated_at)\n VALUES (?, ?, ?, ?)\n ON CONFLICT(run_id, writer) DO UPDATE\n SET checks = excluded.checks, updated_at = excluded.updated_at`,\n [id, writer, JSON.stringify(checks.slice(-this.maxChecks)), Date.now()]\n );\n }\n\n async loadChecks(id: string): Promise> {\n const rows = await this.execRuns(\n `SELECT writer, checks FROM hosted_checks_v2 WHERE run_id = ?`,\n [id]\n );\n const out = new Map();\n for (const [writer, checks] of rows) {\n try {\n out.set(writer as string, JSON.parse(checks as string));\n } catch {\n // corrupt row — ignore\n }\n }\n return out;\n }\n\n async deleteRun(id: string): Promise {\n await this.execRuns(`DELETE FROM hosted_checks_v2 WHERE run_id = ?`, [id]);\n await this.execCell(`DELETE FROM hosted_traffic_v1 WHERE cell_id = ?`, [\n id\n ]);\n await this.execCell(`DELETE FROM hosted_attempts_v1 WHERE cell_id = ?`, [\n id\n ]);\n await this.execRuns(`DELETE FROM hosted_runs_v2 WHERE id = ?`, [id]);\n }\n\n /**\n * A statement on a cell's attempts or traffic. Their tables are created\n * the first time a statement on them fails, as the challenge notes' are.\n */\n private async execCell(sql: string, args: unknown[]): Promise {\n try {\n return await this.exec(sql, args);\n } catch {\n await this.exec(\n `CREATE TABLE IF NOT EXISTS hosted_attempts_v1 (\n cell_id TEXT NOT NULL, n INTEGER NOT NULL, at INTEGER NOT NULL,\n PRIMARY KEY (cell_id, n))`\n );\n await this.exec(\n `CREATE TABLE IF NOT EXISTS hosted_traffic_v1 (\n cell_id TEXT NOT NULL, writer TEXT NOT NULL, row TEXT NOT NULL,\n updated_at INTEGER NOT NULL, PRIMARY KEY (cell_id, writer))`\n );\n return this.exec(sql, args);\n }\n }\n\n async startAttempt(id: string, at: number): Promise {\n const rows = await this.execCell(\n `INSERT INTO hosted_attempts_v1 (cell_id, n, at)\n SELECT ?, COALESCE(MAX(n), 1) + 1, ? FROM hosted_attempts_v1 WHERE cell_id = ?\n ON CONFLICT(cell_id, n) DO NOTHING\n RETURNING n`,\n [id, at, id]\n );\n if (rows[0]?.[0] !== undefined) return Number(rows[0][0]);\n // Another reset took that number at the same moment: one attempt.\n return (await this.loadAttempts(id)).length + 1;\n }\n\n async loadAttempts(id: string): Promise {\n const rows = await this.execCell(\n `SELECT at FROM hosted_attempts_v1 WHERE cell_id = ? ORDER BY n`,\n [id]\n );\n return rows.map(([at]) => Number(at));\n }\n\n async saveTraffic(\n id: string,\n writer: string,\n row: TrafficRow\n ): Promise {\n const json = JSON.stringify(row);\n // Kept only while the cell's rows, this one included, stay under the cap.\n await this.execCell(\n `INSERT INTO hosted_traffic_v1 (cell_id, writer, row, updated_at)\n SELECT ?, ?, ?, ? WHERE\n (SELECT COALESCE(SUM(LENGTH(row)), 0) FROM hosted_traffic_v1\n WHERE cell_id = ? AND writer <> ?) + ? <= ?\n ON CONFLICT(cell_id, writer) DO UPDATE\n SET row = excluded.row, updated_at = excluded.updated_at`,\n [\n id,\n writer,\n json,\n Date.now(),\n id,\n writer,\n json.length,\n TRAFFIC_CELL_BYTES\n ]\n );\n }\n\n async loadTraffic(id: string): Promise> {\n const rows = await this.execCell(\n `SELECT writer, row FROM hosted_traffic_v1 WHERE cell_id = ?`,\n [id]\n );\n const out = new Map();\n for (const [writer, row] of rows) {\n try {\n out.set(writer as string, JSON.parse(row as string) as TrafficRow);\n } catch {\n // corrupt row — ignore\n }\n }\n return out;\n }\n\n private initSnapshots(): Promise {\n this.snapshotsReady ??= this.exec(\n `CREATE TABLE IF NOT EXISTS hosted_snapshots_v1 (\n run_id TEXT NOT NULL, id TEXT NOT NULL, body TEXT NOT NULL,\n created_at INTEGER NOT NULL, PRIMARY KEY (run_id, id))`\n )\n .then(() => undefined)\n .catch((e) => {\n this.snapshotsReady = undefined;\n throw e;\n });\n return this.snapshotsReady;\n }\n\n async saveSnapshot(\n runId: string,\n snapshotId: string,\n body: string\n ): Promise {\n await this.initSnapshots();\n await this.exec(\n `INSERT INTO hosted_snapshots_v1 (run_id, id, body, created_at)\n VALUES (?, ?, ?, ?) ON CONFLICT(run_id, id) DO NOTHING`,\n [runId, snapshotId, body, Date.now()]\n );\n void this.sweepSnapshots().catch(() => {});\n }\n\n async loadSnapshot(\n runId: string,\n snapshotId: string\n ): Promise {\n await this.initSnapshots();\n const rows = await this.exec(\n `SELECT body FROM hosted_snapshots_v1 WHERE run_id = ? AND id = ?`,\n [runId, snapshotId]\n );\n return rows[0]?.[0] as string | undefined;\n }\n\n async listSnapshots(runId: string): Promise {\n await this.initSnapshots();\n const rows = await this.exec(\n `SELECT id, created_at FROM hosted_snapshots_v1 WHERE run_id = ?\n ORDER BY created_at`,\n [runId]\n );\n return rows.map(([id, createdAt]) => ({\n id: id as string,\n createdAt: Number(createdAt)\n }));\n }\n\n async deleteSnapshots(runId: string): Promise {\n await this.initSnapshots();\n await this.exec(`DELETE FROM hosted_snapshots_v1 WHERE run_id = ?`, [\n runId\n ]);\n }\n\n /**\n * A statement on the challenge notes, whose table is created the first\n * time a statement on it fails, as the runs tables are (see execRuns()).\n * Each note carries its requester, a keyed hash of the client's address\n * (never the address); the v1 table, which had none, is no longer read.\n */\n private async execChallenges(sql: string, args: unknown[]): Promise {\n try {\n return await this.exec(sql, args);\n } catch {\n await this.exec(\n `CREATE TABLE IF NOT EXISTS hosted_challenges_v2 (\n cell_id TEXT NOT NULL, requester TEXT NOT NULL, at INTEGER NOT NULL,\n PRIMARY KEY (cell_id, requester))`\n );\n return this.exec(sql, args);\n }\n }\n\n async saveChallenge(\n id: string,\n requester: string,\n at: number\n ): Promise {\n await this.execChallenges(\n `INSERT INTO hosted_challenges_v2 (cell_id, requester, at) VALUES (?, ?, ?)\n ON CONFLICT(cell_id, requester) DO UPDATE SET at = excluded.at`,\n [id, requester, at]\n );\n const now = Date.now();\n if (now - this.lastChallengeSweep < 5 * 60_000) return;\n this.lastChallengeSweep = now;\n void this.exec(`DELETE FROM hosted_challenges_v2 WHERE at < ?`, [\n now - CHALLENGE_RETENTION_MS\n ]).catch(() => {});\n }\n\n async listChallenges(\n since: number,\n requester: string\n ): Promise> {\n const rows = await this.execChallenges(\n `SELECT cell_id, at FROM hosted_challenges_v2\n WHERE requester = ? AND at >= ? ORDER BY at DESC LIMIT 20`,\n [requester, since]\n );\n return rows.map(([id, at]) => ({ id: id as string, at: Number(at) }));\n }\n\n private async sweepSnapshots(): Promise {\n const now = Date.now();\n if (now - this.lastSnapshotSweep < 5 * 60_000) return;\n this.lastSnapshotSweep = now;\n await this.exec(`DELETE FROM hosted_snapshots_v1 WHERE created_at < ?`, [\n now - this.snapshotRetentionMs\n ]);\n }\n\n private async sweep(): Promise {\n const now = Date.now();\n if (now - this.lastSweep < 5 * 60_000) return;\n this.lastSweep = now;\n const cutoff = now - this.retentionMs;\n await this.exec(\n `DELETE FROM hosted_checks_v2 WHERE run_id IN\n (SELECT id FROM hosted_runs_v2 WHERE created_at < ?)`,\n [cutoff]\n );\n for (const table of ['hosted_traffic_v1', 'hosted_attempts_v1']) {\n await this.execCell(\n `DELETE FROM ${table} WHERE cell_id IN\n (SELECT id FROM hosted_runs_v2 WHERE created_at < ?)`,\n [cutoff]\n );\n }\n await this.exec(`DELETE FROM hosted_runs_v2 WHERE created_at < ?`, [\n cutoff\n ]);\n }\n}\n","deleted",false,"label",[47,48,24],"examples","hosted","7dcb6042-d92f-40c5-9cc8-0f661f96e58b",["D",1789043604380],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","imageUrl","userId","f4518a30-f52b-4b12-891c-a8fffb7240f8","pinnedFileId","e6dd13e2-ad13-11f1-a612-1607ee4eb77e","pinPreview","pinMigrated","screenshotVersion","likeCount",0,"orgId","01a07c12-b73a-76de-b96a-421ce8582af6","tursoName","tursoHostname","tursoMeasuredAt","pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_9":10,"_105":-5},"org",{"_9":10,"_99":100,"_101":-5,"_58":-5,"_102":103,"_104":44},"branch",{"_37":89,"_11":90,"_22":30,"_91":49,"_92":-5,"_93":-5,"_94":-5,"_95":-5,"_96":-5,"_97":12,"_98":10},"isOwned",396,"main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","displayName","MCP Conformance","avatar","tier","free","canRestrictVals","profileImageUrl","ctx",{"_82":-5,"_139":140,"_141":142,"_143":144,"_145":44,"_146":44,"_147":44,"_148":34,"_149":-5,"_150":-7,"_151":-7,"_152":66,"_153":44,"_154":44,"_155":-5,"_156":44,"_157":44,"_158":44,"_159":-5},"ENV",{"_110":111,"_112":113,"_114":90,"_115":116,"_117":118,"_119":120,"_121":122,"_123":124,"_125":126,"_127":128,"_129":130,"_131":132,"_133":134,"_135":136,"_137":138},"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"]