[{"_1":2,"_178":-5,"_179":-5},"loaderData",{"_3":4,"_92":93},"root",{"_5":6,"_35":36,"_65":66},"ctx",{"_7":8,"_23":-5,"_24":25,"_26":27,"_28":20,"_29":20,"_30":20,"_31":32,"_33":20,"_34":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","notificationCount",0,"flagDenols","isTeamOrgMember","ENV",{"_37":38,"_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},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","VAL_RUNTIME_NAME","prod","RENDER_GIT_COMMIT","4e736cb42e83c17c10d9f33412034a74b06f3941","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","API_URL","https://api.val.town","clerkState",{"_67":68},"__internal_clerk_state",{"_69":70,"_71":46,"_72":73,"_74":73,"_75":20,"_76":73,"_77":73,"_78":73,"_79":73,"_80":81,"_90":20,"_91":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",{"_82":20,"_19":20,"_83":73,"_84":85,"_86":73,"_87":46,"_88":20,"_89":73},"isSignedIn","proxyUrl","reason","session-token-and-uat-missing","message","publishableKey","isSatellite","domain","__telemetryDisabled","__telemetryDebug","routes/embed.x.$handle.$name.$",{"_94":95,"_96":97,"_98":99,"_100":101,"_151":152,"_175":176,"_177":-5},"handle","cameronpak","name","mcp-registry-subregistry-api","path","backend/database/queries.ts","project",{"_102":103,"_96":97,"_104":105,"_106":-5,"_107":20,"_108":109,"_110":111,"_112":113,"_12":114,"_115":-5,"_116":20,"_117":-5,"_118":-5,"_119":120,"_14":121,"_122":123,"_124":123,"_125":126,"_127":126,"_128":126,"_129":123,"_130":123,"_23":131,"_134":135,"_137":138,"_150":20},"id","51d870cc-a097-11f0-b09c-0224a6c84d84","createdAt",["D",1759523222208],"deletedAt","legacyEnvVars","privacy","public","description","A Subregistry API for the official MCP Registry","imageUrl","https://imagedelivery.net/iHX6Ovru0O7AjmyT5yZRoA/d6a72ebf-a436-4879-84af-204c8360fa00/square512","35ef5666-3780-42d5-ade0-86fe3fdb6bb1","pinnedFileId","pinPreview","pinMigrated","screenshotVersion","likeCount",1,"47e0b4b2-7d41-46e6-8dce-0ae3d76e1a8f","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm",{"_94":95,"_132":133},"profileImageUrl","https://imagedelivery.net/iHX6Ovru0O7AjmyT5yZRoA/7fcc9ac1-f8fb-41e2-0168-af29ef7c6400/square512","org",{"_94":95,"_136":133,"_12":114},"avatar","branch",{"_139":140,"_96":44,"_102":141,"_142":103,"_143":-5,"_144":-5,"_145":-5,"_146":-5,"_147":-5,"_148":97,"_149":95},"version",26,"51d9b5fe-a097-11f0-b09c-0224a6c84d84","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","isOwned","file",{"_102":153,"_96":154,"_155":156,"_157":158,"_159":141,"_160":161,"_162":163,"_104":164,"_139":165,"_166":167,"_168":169,"_170":20,"_171":-5,"_98":172},"19731dc4-a12b-11f0-81c8-0224a6c84d84","queries.ts","fileId","8dc0de38-a0da-11f0-a25f-0224a6c84d84","parentId","8d9dcfc4-a0da-11f0-bb5b-0224a6c84d84","branchId","branchVersion",25,"latest",true,["D",1759586693105],2,"fileType","script","content","import { eq, and, sql, desc, asc } from \"https://esm.sh/drizzle-orm@0.44.6?target=deno&dts\";\nimport type {\n ServerJSON,\n ServerResponse,\n ServerListResponse,\n} from \"npm:mcp-registry-spec-sdk@0.2.0\";\nimport {\n ServerJSONSchema,\n ServerResponseSchema,\n ServerListResponseSchema,\n} from \"npm:mcp-registry-spec-sdk@0.2.0\";\nimport { runMigrations, TABLE_NAME, getDb, serverVersions } from \"./migrations.ts\";\nimport { ingestMarketplaceIcon, deleteMarketplaceIconBlob } from \"../blob.ts\";\n\n// Query layer for MCP Subregistry POC v2\n// - Uses Val Town SQLite\n// - Works with server_versions_poc_v2 created in migrations.ts\n// - Keeps OpenAPI surface unchanged; this only backs the contract\n//\n// Notes:\n// - JSON fields are stored as TEXT (stringified).\n// - Cursor is base64url(JSON {u: updatedAt, s: server_name_lower, v: version}).\n// - Search is simple LIKE against a precomputed lowercased search_text.\n// - MCP capability flags can be provided via publisher meta or derived heuristically.\n\n// ------------- Cursor helpers -------------\ntype CursorObj = { u: string; s: string; v: string };\n\nfunction base64urlEncode(input: string): string {\n return btoa(input).replaceAll(\"+\", \"-\").replaceAll(\"/\", \"_\").replaceAll(\"=\", \"\");\n}\n\nfunction base64urlDecode(input: string): string {\n const pad = input.length % 4 === 2 ? \"==\" : input.length % 4 === 3 ? \"=\" : \"\";\n const b64 = input.replaceAll(\"-\", \"+\").replaceAll(\"_\", \"/\") + pad;\n return atob(b64);\n}\n\nexport function encodeCursor(c: CursorObj): string {\n return base64urlEncode(JSON.stringify(c));\n}\n\nexport function decodeCursor(cursor: string): CursorObj | null {\n try {\n return JSON.parse(base64urlDecode(cursor));\n } catch {\n return null;\n }\n}\n\n// ------------- MCP flag derivation -------------\n\ntype MCPFlags = {\n protocol_version?: string | null;\n has_tools?: boolean | null;\n has_resources?: boolean | null;\n has_prompts?: boolean | null;\n has_roots?: boolean | null;\n has_completions?: boolean | null;\n has_sampling?: boolean | null;\n transports?: unknown | null; // JSON (array or object)\n discovery_links?: unknown | null; // JSON\n client_snippets?: unknown | null; // JSON\n auth_methods?: unknown | null; // JSON (array)\n};\n\nfunction coerceBool(v: unknown): boolean | null {\n if (typeof v === \"boolean\") return v;\n return null;\n}\n\nfunction deriveFromPublisherMeta(payload: ServerJSON): MCPFlags {\n const meta = (payload as any)?._meta?.[\"io.modelcontextprotocol.registry/publisher-provided\"];\n const mcp = meta?.mcp ?? {};\n const caps = mcp?.capabilities; // could be array of strings OR object of booleans\n\n const flags: MCPFlags = {\n protocol_version: mcp?.protocolVersion ?? null,\n has_tools: null,\n has_resources: null,\n has_prompts: null,\n has_roots: null,\n has_completions: null,\n has_sampling: null,\n transports: mcp?.transports ?? null,\n discovery_links: mcp?.discoveryLinks ?? null,\n client_snippets: mcp?.clientSnippets ?? null,\n auth_methods: mcp?.authMethods ?? null,\n };\n\n if (Array.isArray(caps)) {\n const set = new Set(caps.map(String));\n flags.has_tools = set.has(\"tools\") ? true : null;\n flags.has_resources = set.has(\"resources\") ? true : null;\n flags.has_prompts = set.has(\"prompts\") ? true : null;\n flags.has_roots = set.has(\"roots\") ? true : null;\n flags.has_completions = set.has(\"completions\") ? true : null;\n flags.has_sampling = set.has(\"sampling\") ? true : null;\n } else if (caps && typeof caps === \"object\") {\n flags.has_tools = coerceBool(caps.tools);\n flags.has_resources = coerceBool(\n (payload as any).packages?.some((p: any) => p.scope === \"community\" && p.registryType === \"module\")\n );\n flags.has_prompts = coerceBool(caps.prompts);\n flags.has_roots = coerceBool(\n (payload as any).packages?.some((p: any) => p.scope === \"system\")\n );\n flags.has_completions = coerceBool(caps.completions);\n flags.has_sampling = coerceBool(caps.sampling);\n }\n\n return flags;\n}\n\nfunction applyHeuristics(flags: MCPFlags, payload: ServerJSON): MCPFlags {\n const out = { ...flags };\n // If missing, infer a tiny bit from structural hints\n const hasRemotes = Array.isArray((payload as any).remotes) && ((payload as any).remotes?.length ?? 0) > 0;\n const hasPackages = Array.isArray((payload as any).packages) && ((payload as any).packages?.length ?? 0) > 0;\n\n if (out.has_tools == null) out.has_tools = hasPackages || hasRemotes ? true : null;\n if (out.has_resources == null) out.has_resources = hasRemotes ? true : null;\n // leave prompts/roots/completions/sampling as null unless explicitly provided\n if (out.transports == null && hasRemotes) {\n try {\n // pull transportType(s) from remotes if present\n const transports = (payload as any).remotes\n ?.map((r: any) => r?.transportType)\n ?.filter((t: any) => typeof t === \"string\");\n out.transports = transports?.length ? transports : null;\n } catch {\n // ignore\n }\n }\n return out;\n}\n\n// ------------- Search text -------------\n\nfunction stringifySafe(v: unknown): string {\n try {\n if (v == null) return \"\";\n if (typeof v === \"string\") return v;\n return JSON.stringify(v);\n } catch {\n return \"\";\n }\n}\n\nfunction computeSearchText(payload: ServerJSON, flags: MCPFlags): string {\n const parts: string[] = [];\n parts.push(payload.name ?? \"\");\n parts.push(payload.description ?? \"\");\n if ((payload as any).websiteUrl) parts.push((payload as any).websiteUrl);\n const repo = (payload as any).repository;\n if (repo?.url) parts.push(repo.url);\n if (Array.isArray((payload as any).packages)) {\n for (const p of (payload as any).packages) {\n if (p?.name) parts.push(p.name);\n if (p?.identifier) parts.push(p.identifier);\n if (p?.registryType) parts.push(p.registryType);\n if (p?.version) parts.push(p.version);\n }\n }\n if (Array.isArray((payload as any).remotes)) {\n for (const r of (payload as any).remotes) {\n if (r?.url) parts.push(r.url);\n if (r?.transportType) parts.push(r.transportType);\n }\n }\n\n // Publisher-provided meta content\n const publisherMeta = (payload as any)?._meta?.[\"io.modelcontextprotocol.registry/publisher-provided\"];\n parts.push(stringifySafe(publisherMeta));\n\n // MCP flags for discovery via search\n parts.push(\n stringifySafe({\n protocol: flags.protocol_version,\n has_tools: flags.has_tools,\n has_resources: flags.has_resources,\n has_prompts: flags.has_prompts,\n has_roots: flags.has_roots,\n has_completions: flags.has_completions,\n has_sampling: flags.has_sampling,\n transports: flags.transports,\n auth_methods: flags.auth_methods,\n })\n );\n\n return parts.join(\" | \").toLowerCase();\n}\n\n// looks for redeemable marketplace icon in the publisher record\ntype MarketplaceIconDescriptor = { present: boolean; source: string | null };\n\nfunction getMarketplaceIconDescriptor(payload: ServerJSON): MarketplaceIconDescriptor {\n const meta = (payload as any)?._meta;\n if (!meta || typeof meta !== \"object\" || Array.isArray(meta)) {\n return { present: false, source: null };\n }\n const publisher = (meta as any)?.publisher;\n if (!publisher || typeof publisher !== \"object\") {\n return { present: false, source: null };\n }\n if (!Object.prototype.hasOwnProperty.call(publisher, \"marketplaceIcon\")) {\n return { present: false, source: null };\n }\n const raw = (publisher as any).marketplaceIcon;\n if (typeof raw === \"string\") {\n const trimmed = raw.trim();\n return { present: true, source: trimmed.length ? trimmed : null };\n }\n if (raw && typeof raw === \"object\") {\n const record = raw as Record;\n const candidate =\n typeof record.source === \"string\"\n ? record.source\n : typeof record.url === \"string\"\n ? record.url\n : typeof record.dataUrl === \"string\"\n ? record.dataUrl\n : typeof record.data_url === \"string\"\n ? record.data_url\n : undefined;\n if (typeof candidate === \"string\") {\n const trimmed = candidate.trim();\n return {\n present: true,\n source: trimmed.length ? trimmed : null,\n };\n }\n }\n return { present: true, source: null };\n}\n\nasync function ingestMarketplaceIconOrThrow(\n serverName: string,\n version: string,\n source: string,\n): Promise<{ blobKey: string; mime: string }> {\n try {\n return await ingestMarketplaceIcon({ serverName, version, source });\n } catch (err) {\n const detail =\n (err as any)?.problem?.detail ?? (err as Error)?.message ?? \"Failed to ingest marketplaceIcon.\";\n const problem = {\n type: \"about:blank\",\n title: \"Invalid marketplaceIcon\",\n status: 422,\n detail,\n errors: [\n {\n location: \"_meta.publisher.marketplaceIcon\",\n message: detail,\n },\n ],\n };\n const wrapped = new Error(detail);\n (wrapped as any).problem = problem;\n throw wrapped;\n }\n}\n\n// ------------- Response mapping -------------\n\nfunction toServerResponse(row: any): ServerResponse {\n // Support both raw SQL column names and Drizzle schema property names\n const payloadStr = row.payload_json ?? row.payloadJson;\n const p: any = JSON.parse(payloadStr);\n const serverNameLower = row.server_name_lower ?? row.serverNameLower;\n const publishedAt = row.published_at ?? row.publishedAt;\n const updatedAt = row.updated_at ?? row.updatedAt;\n const isLatest = (row.is_latest ?? row.isLatest) as boolean | number;\n const status = row.status;\n const official: Record = {\n serverId: String(serverNameLower),\n versionId: String(row.id),\n publishedAt: String(publishedAt),\n updatedAt: String(updatedAt),\n isLatest: !!isLatest,\n status: String(status),\n };\n const blobIconKey = row.blob_icon_key ?? row.blobIconKey ?? null;\n const blobIconMime = row.blob_icon_mime ?? row.blobIconMime ?? null;\n if (blobIconKey && blobIconMime) {\n official.marketplaceIcon = {\n blobKey: String(blobIconKey),\n mime: String(blobIconMime),\n };\n }\n const publisherProvided = p?._meta?.[\"io.modelcontextprotocol.registry/publisher-provided\"] ?? {};\n const resp: ServerResponse = {\n $schema: p.$schema,\n name: p.name,\n description: p.description,\n version: p.version,\n repository: p.repository,\n websiteUrl: p.websiteUrl,\n packages: p.packages,\n remotes: p.remotes,\n _meta: {\n \"io.modelcontextprotocol.registry/official\": official as any,\n \"io.modelcontextprotocol.registry/publisher-provided\": publisherProvided as any,\n },\n };\n return resp;\n}\n\n// ------------- Public API -------------\n\nexport type ListServersOptions = {\n cursor?: string | null;\n limit?: number | null;\n search?: string | null;\n updatedSince?: string | null;\n version?: string | null;\n};\n\ntype ServerStatus = \"active\" | \"deprecated\" | \"deleted\";\n\nexport async function publishServerVersion(payload: ServerJSON): Promise {\n await runMigrations();\n\n // Strict input validation\n const parsed = await ServerJSONSchema.safeParseAsync(payload);\n if (!parsed.success) {\n throw new Error(\"Invalid server JSON\");\n }\n\n const now = new Date().toISOString();\n const serverName = payload.name;\n const serverNameLower = serverName.toLowerCase();\n const version = payload.version;\n\n let flags = deriveFromPublisherMeta(payload);\n flags = applyHeuristics(flags, payload);\n\n const searchText = computeSearchText(payload, flags);\n\n const iconDescriptor = getMarketplaceIconDescriptor(payload);\n let iconResult: { blobKey: string; mime: string } | null = null;\n if (iconDescriptor.present && iconDescriptor.source) {\n iconResult = await ingestMarketplaceIconOrThrow(serverName, version, iconDescriptor.source);\n }\n\n const db = getDb();\n // Insert\n await db.insert(serverVersions).values({\n serverName,\n serverNameLower,\n version,\n payloadJson: JSON.stringify(payload),\n publishedAt: now,\n updatedAt: now,\n isLatest: false,\n status: \"active\",\n searchText,\n blobIconKey: iconResult?.blobKey ?? null,\n blobIconMime: iconResult?.mime ?? null,\n protocolVersion: flags.protocol_version ?? null,\n hasTools: flags.has_tools ?? null,\n hasResources: flags.has_resources ?? null,\n hasPrompts: flags.has_prompts ?? null,\n hasRoots: flags.has_roots ?? null,\n hasCompletions: flags.has_completions ?? null,\n hasSampling: flags.has_sampling ?? null,\n transports: flags.transports ? JSON.stringify(flags.transports) : null,\n discoveryLinks: flags.discovery_links ? JSON.stringify(flags.discovery_links) : null,\n clientSnippets: flags.client_snippets ? JSON.stringify(flags.client_snippets) : null,\n authMethods: flags.auth_methods ? JSON.stringify(flags.auth_methods) : null,\n });\n\n // Recompute latest for this server:\n // 1) clear previous\n await db\n .update(serverVersions)\n .set({ isLatest: false })\n .where(eq(serverVersions.serverNameLower, serverNameLower));\n // 2) set the newest by (publishedAt desc, id desc)\n const newest = await db\n .select({ id: serverVersions.id })\n .from(serverVersions)\n .where(eq(serverVersions.serverNameLower, serverNameLower))\n .orderBy(desc(serverVersions.publishedAt), desc(serverVersions.id))\n .limit(1);\n if (newest[0]?.id != null) {\n await db\n .update(serverVersions)\n .set({ isLatest: true })\n .where(eq(serverVersions.id, newest[0].id));\n }\n\n // Return the just-published version\n const rows = await db\n .select()\n .from(serverVersions)\n .where(and(eq(serverVersions.serverNameLower, serverNameLower), eq(serverVersions.version, version)))\n .limit(1);\n const row = rows[0];\n if (!row) throw new Error(\"Failed to publish server version\");\n const out = toServerResponse(row);\n // Strict output validation\n await ServerResponseSchema.safeParse(out);\n\n return out;\n}\n\nexport async function updateServerVersion(\n serverName: string,\n version: string,\n payload: ServerJSON\n): Promise {\n await runMigrations();\n\n const serverNameLower = serverName.toLowerCase();\n const db = getDb();\n const existingRows = await db\n .select()\n .from(serverVersions)\n .where(and(eq(serverVersions.serverNameLower, serverNameLower), eq(serverVersions.version, version)))\n .limit(1);\n const existing = existingRows[0];\n if (!existing) {\n throw new Error(\"Server version not found\");\n }\n\n const storedPayloadJson =\n (existing as Record).payloadJson ??\n (existing as Record).payload_json ??\n null;\n\n let storedPayload: ServerJSON | null = null;\n if (typeof storedPayloadJson === \"string\") {\n try {\n storedPayload = JSON.parse(storedPayloadJson) as ServerJSON;\n } catch {\n storedPayload = null;\n }\n }\n\n if (!storedPayload || !deepEqual(storedPayload, payload)) {\n const err = new Error(\"ImmutableVersionConflict\");\n (err as any).code = \"ImmutableVersionConflict\";\n throw err;\n }\n\n const response = toServerResponse(existing);\n const { success } = await ServerResponseSchema.safeParseAsync(response);\n if (!success) {\n throw new Error(\"Invalid server response\");\n }\n return response;\n}\n\nexport async function updateServerStatus(\n serverName: string,\n version: string,\n status: ServerStatus,\n): Promise {\n await runMigrations();\n const serverNameLower = serverName.toLowerCase();\n const db = getDb();\n const existingRows = await db\n .select()\n .from(serverVersions)\n .where(and(eq(serverVersions.serverNameLower, serverNameLower), eq(serverVersions.version, version)))\n .limit(1);\n const existing = existingRows[0];\n if (!existing) {\n throw new Error(\"Server version not found\");\n }\n\n const currentStatus = String(existing.status ?? \"active\").toLowerCase() as ServerStatus;\n const normalizedStatus = status;\n\n if (currentStatus === \"deleted\" && normalizedStatus !== \"deleted\") {\n const err = new Error(\"StatusTransitionNotAllowed\");\n (err as any).code = \"StatusTransitionNotAllowed\";\n throw err;\n }\n\n if (currentStatus === normalizedStatus) {\n const response = toServerResponse(existing);\n const { success } = await ServerResponseSchema.safeParseAsync(response);\n if (!success) {\n throw new Error(\"Invalid server response\");\n }\n return response;\n }\n\n const now = new Date().toISOString();\n await db\n .update(serverVersions)\n .set({ status: normalizedStatus, updatedAt: now })\n .where(eq(serverVersions.id, existing.id))\n .limit(1);\n\n await db\n .update(serverVersions)\n .set({ isLatest: false })\n .where(eq(serverVersions.serverNameLower, serverNameLower));\n\n const newestActive = await db\n .select({ id: serverVersions.id })\n .from(serverVersions)\n .where(and(eq(serverVersions.serverNameLower, serverNameLower), eq(serverVersions.status, \"active\")))\n .orderBy(desc(serverVersions.publishedAt), desc(serverVersions.id))\n .limit(1);\n\n if (newestActive[0]?.id != null) {\n await db\n .update(serverVersions)\n .set({ isLatest: true })\n .where(eq(serverVersions.id, newestActive[0].id))\n .limit(1);\n }\n\n const updatedRows = await db\n .select()\n .from(serverVersions)\n .where(eq(serverVersions.id, existing.id))\n .limit(1);\n const updated = updatedRows[0];\n if (!updated) {\n throw new Error(\"Server version not found after status update\");\n }\n\n const response = toServerResponse(updated);\n const { success } = await ServerResponseSchema.safeParseAsync(response);\n if (!success) {\n throw new Error(\"Invalid server response\");\n }\n return response;\n}\n\nexport async function getLatestServerByName(\n serverName: string\n): Promise {\n await runMigrations();\n const serverNameLower = serverName.toLowerCase();\n const db = getDb();\n const rows = await db\n .select()\n .from(serverVersions)\n .where(\n and(\n eq(serverVersions.serverNameLower, serverNameLower),\n eq(serverVersions.isLatest, true),\n eq(serverVersions.status, \"active\")\n )\n )\n .limit(1);\n const row = rows[0];\n if (!row) return null;\n const out = toServerResponse(row);\n const { success } = await ServerResponseSchema.safeParseAsync(out);\n if (!success) {\n throw new Error(\"Invalid server response\");\n }\n return out;\n}\n\nexport async function getServerByNameVersion(\n serverName: string,\n version: string\n): Promise {\n await runMigrations();\n const serverNameLower = serverName.toLowerCase();\n const db = getDb();\n const rows = await db\n .select()\n .from(serverVersions)\n .where(\n and(\n eq(serverVersions.serverNameLower, serverNameLower),\n eq(serverVersions.version, version),\n eq(serverVersions.status, \"active\")\n )\n )\n .limit(1);\n const row = rows[0];\n if (!row) return null;\n const out = toServerResponse(row);\n const { success } = await ServerResponseSchema.safeParseAsync(out);\n if (!success) {\n throw new Error(\"Invalid server response\");\n }\n return out;\n}\n\nexport async function listServerVersions(\n serverName: string\n): Promise {\n await runMigrations();\n const serverNameLower = serverName.toLowerCase();\n const db = getDb();\n const rows = await db\n .select()\n .from(serverVersions)\n .where(\n and(\n eq(serverVersions.serverNameLower, serverNameLower),\n eq(serverVersions.status, \"active\")\n )\n )\n .orderBy(desc(serverVersions.publishedAt), desc(serverVersions.id));\n const out: ServerResponse[] = rows.map(toServerResponse);\n // Validate each (can be disabled later for perf)\n for (const r of out) {\n const { success } = await ServerResponseSchema.safeParseAsync(r);\n if (!success) {\n throw new Error(\"Invalid server response\");\n }\n }\n return out;\n}\n\nfunction deepEqual(a: unknown, b: unknown): boolean {\n if (a === b) {\n return true;\n }\n if (typeof a === \"number\" && typeof b === \"number\" && Number.isNaN(a) && Number.isNaN(b)) {\n return true;\n }\n if (typeof a !== typeof b) {\n return false;\n }\n if (Array.isArray(a)) {\n if (!Array.isArray(b)) {\n return false;\n }\n if (a.length !== b.length) {\n return false;\n }\n for (let i = 0; i < a.length; i += 1) {\n if (!deepEqual(a[i], b[i])) {\n return false;\n }\n }\n return true;\n }\n if (typeof a === \"object\" && a !== null && b !== null) {\n const aKeys = Object.keys(a as Record);\n const bKeys = Object.keys(b as Record);\n if (aKeys.length !== bKeys.length) {\n return false;\n }\n for (const key of aKeys) {\n if (!Object.prototype.hasOwnProperty.call(b, key)) {\n return false;\n }\n if (\n !deepEqual(\n (a as Record)[key],\n (b as Record)[key],\n )\n ) {\n return false;\n }\n }\n return true;\n }\n return false;\n}\n\n// ------------- Listing with pagination -------------\n\nfunction tokenizeSearch(q?: string | null): string[] {\n if (!q) return [];\n return String(q).toLowerCase().split(/\\s+/).filter(Boolean);\n}\n\nexport async function listServers(\n options: ListServersOptions = {}\n): Promise {\n await runMigrations();\n const db = getDb();\n\n const limit = Math.max(1, Math.min(options.limit ?? 25, 100));\n const cur = options.cursor ? decodeCursor(options.cursor) : null;\n\n // Build WHERE condition\n let cond: any = eq(serverVersions.status, \"active\");\n if (cur) {\n const cursorCond = sql`(${serverVersions.updatedAt} < ${cur.u}\n OR (${serverVersions.updatedAt} = ${cur.u} AND ${serverVersions.serverNameLower} > ${cur.s})\n OR (${serverVersions.updatedAt} = ${cur.u} AND ${serverVersions.serverNameLower} = ${cur.s} AND ${serverVersions.version} < ${cur.v}))`;\n cond = and(cond, cursorCond as any);\n }\n\n if (options.updatedSince) {\n const updatedCond = sql`${serverVersions.updatedAt} > ${options.updatedSince}`;\n cond = and(cond, updatedCond as any);\n }\n\n const versionFilter = options.version?.trim();\n if (versionFilter) {\n if (versionFilter.toLowerCase() === \"latest\") {\n cond = and(cond, eq(serverVersions.isLatest, true));\n } else {\n cond = and(cond, eq(serverVersions.version, versionFilter));\n }\n }\n\n const tokens = tokenizeSearch(options.search);\n for (const t of tokens) {\n const likeCond = sql`${serverVersions.searchText} LIKE ${\"%\" + t + \"%\"}`;\n cond = and(cond, likeCond as any);\n }\n\n const rows = await db\n .select()\n .from(serverVersions)\n .where(cond)\n .orderBy(\n desc(serverVersions.updatedAt),\n asc(serverVersions.serverNameLower),\n desc(serverVersions.version),\n desc(serverVersions.id),\n )\n .limit(limit);\n\n const servers = rows.map(toServerResponse);\n\n const last = rows[rows.length - 1];\n const nextCursor = last\n ? encodeCursor({\n u: String(last.updatedAt),\n s: String(last.serverNameLower),\n v: String(last.version),\n })\n : undefined;\n\n const out: ServerListResponse = {\n servers,\n metadata: {\n count: servers.length,\n ...(nextCursor ? { nextCursor } : {}),\n },\n };\n // Strict output validation\n const { success } = await ServerListResponseSchema.safeParseAsync(out);\n if (!success) {\n throw new Error(\"Invalid server list response\");\n }\n return out;\n}\n\nexport async function getServerById(\n id: number | string\n): Promise {\n const numericId = typeof id === \"string\" ? Number(id) : id;\n if (!Number.isInteger(numericId) || numericId <= 0) {\n return null;\n }\n\n await runMigrations();\n const db = getDb();\n const rows = await db\n .select()\n .from(serverVersions)\n .where(and(eq(serverVersions.id, numericId), eq(serverVersions.status, \"active\")))\n .limit(1);\n\n const row = rows[0];\n if (!row) return null;\n\n const out = toServerResponse(row);\n const { success } = await ServerResponseSchema.safeParseAsync(out);\n if (!success) {\n throw new Error(\"Invalid server response\");\n }\n return out;\n}","deleted","label",[173,174,154],"backend","database","permalink","https://www.val.town/x/cameronpak/mcp-registry-subregistry-api/code/backend/database/queries.ts","extension","actionData","errors"]