[{"_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","src/hosted/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/src/hosted/store.ts","extension","id","1ff0bfd3-4ea6-47c7-acbe-aadc7381e2e1","store.ts","fileId","d343f09e-ad13-11f1-892b-1607ee4eb77e","parentId","11abc952-e3be-41e6-ac33-6929c3af1284","branchId","fdc11199-683b-41f1-a3c5-d5ac53972f86","branchVersion",387,"latest",true,"createdAt",["D",1789379124104],"version",7,"fileType","script","content","/**\n * Run persistence for the hosted conformance server.\n *\n * A long-lived Node process keeps every run in memory and needs none of this.\n * Serverless hosts (val.town, Deno Deploy, …) load-balance one run's requests\n * across short-lived isolates, so the isolate that answers GET /results is\n * often not the one that saw the MCP traffic. A RunStore lets each isolate\n * write through what it observed and lets any isolate serve a merged view:\n *\n * - run metadata (cell id → scenario) so the results page can list which\n * cells of a run were exercised, and tear them all down together;\n * - checks, keyed by (run, writer): each isolate owns its own row and\n * replaces it wholesale after every request, so concurrent writers never\n * clobber each other and no append ordering is needed. The hosted\n * layer's own checks (client identity, probe notes) go to a row per\n * build of the cell in the isolate, so a cell evicted from memory and\n * rebuilt does not write over what it recorded before.\n *\n * The merged log is re-judged at results time by a fresh scenario instance\n * (see SessionManager.results), which is what turns \"isolate B never saw a\n * tools/call\" from a false FAILURE into the union of what A and B saw.\n *\n * It also keeps snapshots: a run's report frozen at one moment (POST\n * /results//freeze), stored as its JSON so any isolate can serve\n * the permalink and later traffic cannot change it.\n *\n * Per cell it also keeps its attempts — the times it was reset (POST\n * /results//reset), each starting a new attempt whose checks and\n * traffic are written to rows of their own (see attemptOfWriter()) — and\n * its traffic, one row per writer like the checks (see ./traffic.ts).\n */\n\nimport type { ConformanceCheck } from '../types.ts';\nimport { TRAFFIC_CELL_BYTES, type TrafficRow } from './traffic.ts';\n\nexport interface SnapshotInfo {\n id: string;\n /** Milliseconds since the epoch. */\n createdAt: number;\n}\n\n/** How long a store keeps what it holds, as the landing page states it. */\nexport interface StoreRetention {\n /** A cell's recorded traffic, counted from the cell's first request. */\n runMs: number;\n /** A frozen report, counted from when it was frozen. */\n snapshotMs: number;\n}\n\nexport interface RunStore {\n /** Set by a store that deletes old runs and snapshots by itself. */\n readonly retention?: StoreRetention;\n saveRun(id: string, scenarioName: string): Promise;\n /** Scenario name for a run id, or undefined if no isolate ever saw it. */\n loadRun(id: string): Promise;\n /**\n * Every saved run whose id starts with `prefix`. Cell ids are\n * `//`, so `/` lists one run's cells.\n */\n listRuns(\n prefix: string\n ): Promise>;\n saveChecks(\n id: string,\n writer: string,\n checks: ConformanceCheck[]\n ): Promise;\n /** All writers' check lists for a run, keyed by writer id. */\n loadChecks(id: string): Promise>;\n deleteRun(id: string): Promise;\n /**\n * Keep a run's frozen report. `body` is its JSON, stored as given; a\n * snapshot id already taken keeps its first body.\n */\n saveSnapshot(runId: string, snapshotId: string, body: string): Promise;\n loadSnapshot(runId: string, snapshotId: string): Promise;\n /** A run's snapshots, oldest first. */\n listSnapshots(runId: string): Promise;\n deleteSnapshots(runId: string): Promise;\n /**\n * Note that cell `id` answered a request from `requester` with a sign-in\n * challenge (401) at `at` (ms since the epoch), replacing that pair's\n * earlier note. `requester` is a keyed hash of the client's address, ''\n * when it is unknown (see requesterHasher() in ./root-prm.ts). A request\n * that names no cell (the origin-root protected resource metadata) is\n * attributed from the notes of its own requester, whichever process sent\n * the challenge. A store may drop notes after an hour.\n */\n saveChallenge(id: string, requester: string, at: number): Promise;\n /**\n * Cells whose latest challenge to `requester` is at or after `since`,\n * latest first. Never another requester's cells.\n */\n listChallenges(\n since: number,\n requester: string\n ): Promise>;\n /**\n * Start a new attempt at cell `id`, reset at `at` (ms since the epoch),\n * and return its number: 2 for the cell's first reset. Two resets at once\n * may start one attempt between them.\n */\n startAttempt(id: string, at: number): Promise;\n /**\n * When cell `id` was reset, oldest first: attempt n + 2 started at\n * `resets[n]`, so the current attempt is `resets.length + 1`.\n */\n loadAttempts(id: string): Promise;\n /**\n * Replace one writer's traffic row for cell `id`. A store may refuse a\n * row that would take the cell's traffic over TRAFFIC_CELL_BYTES; the\n * row it keeps then is the writer's last one that fitted.\n */\n saveTraffic(id: string, writer: string, row: TrafficRow): Promise;\n /** All writers' traffic rows for cell `id`, keyed by writer id. */\n loadTraffic(id: string): Promise>;\n}\n\n/**\n * The attempt a checks or traffic row belongs to, from its writer id:\n * `a:` for attempt n, a plain id for the first (every row\n * written before cells could be reset).\n */\nexport function attemptOfWriter(writer: string): number {\n const m = /^a(\\d+):/.exec(writer);\n return m ? Number(m[1]) : 1;\n}\n\n/** The writer id `writer` uses for its rows of `attempt`. */\nexport function attemptWriter(writer: string, attempt: number): string {\n return attempt > 1 ? `a${attempt}:${writer}` : writer;\n}\n\n/** How long a store must keep a challenge note (see saveChallenge()). */\nexport const CHALLENGE_RETENTION_MS = 3600_000;\n\n/**\n * In-process store — used by tests to exercise the merge path, and by a\n * single long-lived process for its snapshots.\n */\nexport class MemoryRunStore implements RunStore {\n private runs = new Map();\n private checks = new Map>();\n private snapshots = new Map<\n string,\n Map\n >();\n\n async saveRun(id: string, scenarioName: string): Promise {\n if (!this.runs.has(id)) this.runs.set(id, scenarioName);\n }\n async loadRun(id: string): Promise {\n return this.runs.get(id);\n }\n async listRuns(\n prefix: string\n ): Promise> {\n return Array.from(this.runs.entries())\n .filter(([id]) => id.startsWith(prefix))\n .map(([id, scenarioName]) => ({ id, scenarioName }));\n }\n async saveChecks(\n id: string,\n writer: string,\n checks: ConformanceCheck[]\n ): Promise {\n let byWriter = this.checks.get(id);\n if (!byWriter) this.checks.set(id, (byWriter = new Map()));\n byWriter.set(\n writer,\n checks.map((c) => ({ ...c }))\n );\n }\n async loadChecks(id: string): Promise> {\n return new Map(this.checks.get(id) ?? []);\n }\n async deleteRun(id: string): Promise {\n this.runs.delete(id);\n this.checks.delete(id);\n this.attempts.delete(id);\n this.traffic.delete(id);\n }\n async saveSnapshot(\n runId: string,\n snapshotId: string,\n body: string\n ): Promise {\n let byId = this.snapshots.get(runId);\n if (!byId) this.snapshots.set(runId, (byId = new Map()));\n if (!byId.has(snapshotId)) {\n byId.set(snapshotId, { body, createdAt: Date.now() });\n }\n }\n async loadSnapshot(\n runId: string,\n snapshotId: string\n ): Promise {\n return this.snapshots.get(runId)?.get(snapshotId)?.body;\n }\n async listSnapshots(runId: string): Promise {\n return Array.from(this.snapshots.get(runId) ?? [], ([id, s]) => ({\n id,\n createdAt: s.createdAt\n }));\n }\n async deleteSnapshots(runId: string): Promise {\n this.snapshots.delete(runId);\n }\n /** Keyed by requester and cell id (a requester hash has no space). */\n private challenges = new Map<\n string,\n { id: string; requester: string; at: number }\n >();\n async saveChallenge(\n id: string,\n requester: string,\n at: number\n ): Promise {\n for (const [key, c] of this.challenges) {\n if (c.at < at - CHALLENGE_RETENTION_MS) this.challenges.delete(key);\n }\n this.challenges.set(`${requester} ${id}`, { id, requester, at });\n }\n async listChallenges(\n since: number,\n requester: string\n ): Promise> {\n return Array.from(this.challenges.values())\n .filter((c) => c.requester === requester && c.at >= since)\n .sort((a, b) => b.at - a.at)\n .map(({ id, at }) => ({ id, at }));\n }\n private attempts = new Map();\n async startAttempt(id: string, at: number): Promise {\n const resets = this.attempts.get(id) ?? [];\n resets.push(at);\n this.attempts.set(id, resets);\n return resets.length + 1;\n }\n async loadAttempts(id: string): Promise {\n return [...(this.attempts.get(id) ?? [])];\n }\n private traffic = new Map>();\n async saveTraffic(\n id: string,\n writer: string,\n row: TrafficRow\n ): Promise {\n let byWriter = this.traffic.get(id);\n if (!byWriter) this.traffic.set(id, (byWriter = new Map()));\n const json = JSON.stringify(row);\n let others = 0;\n for (const [w, r] of byWriter) if (w !== writer) others += r.length;\n if (others + json.length > TRAFFIC_CELL_BYTES) return;\n byWriter.set(writer, json);\n }\n async loadTraffic(id: string): Promise> {\n const out = new Map();\n for (const [w, json] of this.traffic.get(id) ?? [])\n out.set(w, JSON.parse(json) as TrafficRow);\n return out;\n }\n}\n","deleted",false,"label",[47,48,24],"src","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"]