[{"_1":2,"_172":-5,"_173":-5},"loaderData",{"_3":4,"_91":92},"root",{"_5":6,"_34":35,"_64":65},"ctx",{"_7":8,"_23":-5,"_24":25,"_26":27,"_28":20,"_29":20,"_30":20,"_31":32,"_33":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","ENV",{"_36":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},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","VAL_RUNTIME_NAME","prod","RENDER_GIT_COMMIT","73d011c55f6ff6e543547a2f801bf2081197a5a4","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",{"_66":67},"__internal_clerk_state",{"_68":69,"_70":45,"_71":72,"_73":72,"_74":20,"_75":72,"_76":72,"_77":72,"_78":72,"_79":80,"_89":20,"_90":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",{"_81":20,"_19":20,"_82":72,"_83":84,"_85":72,"_86":45,"_87":20,"_88":72},"isSignedIn","proxyUrl","reason","session-token-and-uat-missing","message","publishableKey","isSatellite","domain","__telemetryDisabled","__telemetryDebug","routes/embed.x.$handle.$name.$",{"_93":94,"_95":96,"_97":98,"_99":100,"_146":147,"_169":170,"_171":-5},"handle","supagroova","name","LiveStormMCP","path","src/mcp.ts","project",{"_101":102,"_95":96,"_103":104,"_105":-5,"_106":20,"_107":108,"_109":-5,"_110":-5,"_12":111,"_112":-5,"_113":20,"_114":-5,"_115":32,"_14":116,"_117":118,"_119":118,"_120":121,"_122":121,"_123":121,"_124":118,"_125":118,"_23":126,"_129":130,"_132":133,"_145":20},"id","961dd0da-3227-11f0-bafd-569c3dd06744","createdAt",["D",1747380605211],"deletedAt","legacyEnvVars","privacy","public","description","imageUrl","02a026b0-155c-11f0-bab6-8581b0669677","pinnedFileId","pinPreview","screenshotVersion","likeCount","0cbe3c65-e427-46ee-ace5-57423bb4cc88","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm",{"_93":94,"_127":128},"profileImageUrl","https://img.clerk.com/eyJ0eXBlIjoicHJveHkiLCJzcmMiOiJodHRwczovL2ltYWdlcy5jbGVyay5kZXYvb2F1dGhfZ2l0aHViL2ltZ18ydlV6ZHA5R08xbXRmR25GTDFNdkRqZ0NqOGIifQ","org",{"_93":94,"_131":128},"avatar","branch",{"_134":135,"_95":43,"_101":136,"_137":102,"_138":-5,"_139":-5,"_140":-5,"_141":-5,"_142":-5,"_143":96,"_144":94},"version",245,"961e2f62-3227-11f0-bafd-569c3dd06744","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","isOwned","file",{"_101":148,"_95":149,"_150":151,"_152":153,"_154":136,"_155":156,"_157":158,"_103":159,"_134":160,"_161":162,"_163":164,"_165":20,"_166":-5,"_97":167},"3d46ac18-41ed-11f0-bf2d-76b3cceeab13","mcp.ts","fileId","99adff20-3229-11f0-a2d7-569c3dd06744","parentId","24db8e42-3a3a-11f0-b6b1-9e149126039e","branchId","branchVersion",239,"latest",true,["D",1749114763950],85,"fileType","script","content","import {\n McpServer,\n ResourceTemplate,\n} from \"npm:@modelcontextprotocol/sdk/server/mcp.js\";\nimport {\n extractGetEndpoints,\n extractMutationEndpoints,\n fetchOpenApiSpec,\n proxyRequest,\n} from \"../src/livestorm.ts\";\nimport { z } from \"npm:zod\";\nimport type { OperationObject, SchemaObject } from \"./types.ts\";\n\ntype ZodTypeAny = z.ZodTypeAny;\ntype ZodObject = z.ZodObject;\n\n// Cache for the MCP server instance\nlet mcpServerInstance: McpServer | null = null;\n\n// Helper type for parameter schemas\ntype ParameterSchema = {\n type: \"string\" | \"number\" | \"boolean\" | \"object\" | \"array\";\n description?: string;\n required?: boolean;\n items?: ParameterSchema;\n properties?: Record;\n};\n\n/**\n * Sets up the MCP server with resources and tools based on the Livestorm API\n * Uses a cached instance if available\n */\nexport async function setupMcpServer(): Promise {\n // Return cached instance if available\n if (mcpServerInstance) {\n return mcpServerInstance;\n }\n\n // Create a new MCP server\n const server = new McpServer({\n name: \"livestorm-api-server\",\n version: \"1.0.0\",\n description: \"MCP server that provides access to Livestorm API endpoints\",\n }, { capabilities: { logging: {} } });\n\n try {\n console.log(\"Fetching Livestorm API OpenAPI spec...\");\n // Fetch the OpenAPI spec\n const openApiSpec = await fetchOpenApiSpec();\n\n // Extract GET endpoints (Resources)\n const getEndpoints = extractGetEndpoints(openApiSpec);\n\n // Extract mutation endpoints (Tools)\n const mutationEndpoints = extractMutationEndpoints(openApiSpec);\n\n // Register Resources\n for (const [operationId, endpoint] of Object.entries(getEndpoints)) {\n registerResource(server, operationId, endpoint);\n }\n\n // Register Tools\n for (const [operationId, endpoint] of Object.entries(mutationEndpoints)) {\n registerTool(server, operationId, endpoint);\n }\n\n // Cache the server instance\n mcpServerInstance = server;\n\n return server;\n } catch (error) {\n console.error(\"Error setting up MCP server:\", error);\n throw error;\n }\n}\n\n/**\n * Registers a GET endpoint as an MCP Resource\n */\nfunction registerResource(\n server: McpServer,\n operationId: string,\n endpoint: { path: string; operation: any },\n) {\n const { path, operation } = endpoint;\n const name = operation.summary?.replace(/\\s+/g, \"_\").toLowerCase() ||\n nameFromOperationId(operationId);\n const resourcePath = `livestorm:/${path}` as string;\n const resourceTpl = new ResourceTemplate(resourcePath, {\n list: undefined,\n }) as ResourceTemplate;\n\n const resourceCallback = async (uri: URL, params: any) => {\n console.log(\"Resource callback called for endpoint:\", endpoint);\n console.log(\"Resource callback called with params:\", params);\n try {\n // Extract path parameters from the URL\n const pathParams: Record = {};\n const queryParams: Record = {};\n const headers: Headers = new Headers();\n\n // Process path and query parameters\n if (operation.parameters) {\n for (const param of operation.parameters) {\n if (param.in === \"query\" && params[param.name] !== undefined) {\n queryParams[param.name] = String(params[param.name]);\n } else if (param.in === \"path\") {\n // Extract path parameters from the URL\n const paramName = param.name;\n const paramValue = uri.pathname.split(\"/\").pop();\n if (paramValue) {\n pathParams[paramName] = paramValue;\n }\n }\n }\n }\n\n // Add any additional headers from params if they exist\n if (params.headers) {\n Object.entries(params.headers as Record).forEach(\n ([key, value]) => {\n if (value !== undefined && value !== null) {\n headers.set(key, `${value}`);\n }\n },\n );\n }\n\n // Make the request to the Livestorm API\n const response = await proxyRequest(\n path,\n \"GET\",\n { ...pathParams, ...queryParams },\n );\n\n if (!response.ok) {\n const errorText = await response.text();\n throw new Error(\n `Livestorm API error: ${response.status} ${response.statusText} - ${errorText}`,\n );\n }\n\n const data = await response.json();\n return {\n contents: [{\n uri: uri.href,\n text: JSON.stringify(data),\n }],\n };\n } catch (error) {\n console.error(`Error in resource ${operationId}:`, error);\n throw error;\n }\n };\n\n // Create a resource template with the path\n if (resourcePath.includes(\"id}\")) {\n server.resource(name, resourceTpl, resourceCallback);\n } else {\n server.resource(name, resourcePath, resourceCallback);\n }\n}\n\n/**\n * Registers a POST, PUT, or DELETE endpoint as an MCP Tool\n */\nfunction registerTool(\n server: McpServer,\n operationId: string,\n endpoint: { method: string; path: string; operation: any },\n) {\n const { method, path, operation } = endpoint;\n\n // Create parameter schema from the operation\n const parameterSchema = createParameterSchema(operation);\n\n // Register the tool with the server\n server.tool(\n operation.summary?.replace(/\\s+/g, \"_\").toLowerCase() ||\n nameFromOperationId(operationId),\n operation.summary,\n parameterSchema.inputSchema,\n async (params: Record = {}) => {\n try {\n console.log(\n \"Tool callback called for operationId:\",\n nameFromOperationId(operationId),\n );\n console.log(\"Tool callback called with params:\", params);\n\n // Extract path and query parameters\n const pathParams: Record = {};\n const queryParams: Record = {};\n const headers: Record = {};\n\n // Process parameters based on their location\n if (operation.parameters) {\n for (const param of operation.parameters) {\n const paramValue = params[param.name];\n if (param.in === \"path\" && paramValue !== undefined) {\n pathParams[param.name] = `${paramValue}`;\n } else if (param.in === \"query\" && paramValue !== undefined) {\n queryParams[param.name] = `${paramValue}`;\n } else if (param.in === \"header\" && paramValue !== undefined) {\n headers[param.name] = `${paramValue}`;\n }\n }\n }\n\n // Process request body if present\n let body: any = undefined;\n if (params.body !== undefined) {\n body = params.body;\n }\n\n // Create a new Headers instance\n const requestHeaders = new Headers();\n\n // Copy existing headers\n for (const [key, value] of Object.entries(headers)) {\n requestHeaders.set(key, `${value}`);\n }\n\n // Add Authorization header if not already present\n if (\n !requestHeaders.has(\"Authorization\") && params.headers?.Authorization\n ) {\n const authValue = params.headers.Authorization;\n if (typeof authValue === \"string\") {\n requestHeaders.set(\"Authorization\", authValue);\n } else if (authValue && typeof authValue === \"object\") {\n requestHeaders.set(\"Authorization\", JSON.stringify(authValue));\n } else if (authValue !== undefined && authValue !== null) {\n requestHeaders.set(\"Authorization\", `${authValue}`);\n }\n }\n\n // Make the request to the Livestorm API\n const response = await proxyRequest(\n path,\n method,\n { ...pathParams, ...queryParams },\n body,\n );\n\n if (!response.ok) {\n const errorText = await response.text();\n throw new Error(\n `Livestorm API error: ${response.status} ${response.statusText} - ${errorText}`,\n );\n }\n\n // Return the response data\n const data = await response.json();\n return {\n content: [{\n type: \"text\",\n text: JSON.stringify(data),\n }],\n };\n } catch (error) {\n console.error(`Error in tool ${operationId}:`, error);\n throw error;\n }\n },\n );\n}\n\n/**\n * Converts an operation ID to a name for the MCP server\n */\nfunction nameFromOperationId(operationId: string): string {\n return operationId\n // Replace {id} with 'by ID'\n .replace(/\\{id\\}/g, \" by ID\")\n // Replace {resource_id} with 'by Resource ID'\n .replace(/\\{(\\w+)_id\\}/g, \" by $1 ID\")\n // Convert to title case\n .replace(/^[a-z]+/, (verb) => verb.charAt(0).toUpperCase() + verb.slice(1))\n // Convert to lower case\n .toLowerCase();\n}\n\n/**\n * Creates a tool schema from an OpenAPI operation\n * Returns an object with input and output schemas using Zod\n *\n * Example output:\n * {\n * description: \"Get weather information for a city\",\n * inputSchema: {\n * city: z.string().describe(\"City name\"),\n * country: z.string().describe(\"Country code (e.g., US, UK)\")\n * },\n * outputSchema: {\n * temperature: z.object({\n * celsius: z.number(),\n * fahrenheit: z.number()\n * }),\n * conditions: z.enum([\"sunny\", \"cloudy\", \"rainy\", \"stormy\", \"snowy\"]),\n * humidity: z.number().min(0).max(100),\n * wind: z.object({\n * speed_kmh: z.number(),\n * direction: z.string()\n * })\n * }\n * }\n */\nexport function createParameterSchema(operation: OperationObject): {\n description: string;\n inputSchema: Record;\n} {\n const inputSchema: Record = {};\n\n const requestSchema = operation.requestBody\n ?.content[\"application/vnd.api+json\"]?.schema;\n const responseSchema = operation.responses[\"201\"]\n ?.content[\"application/vnd.api+json\"]?.schema?.properties?.data.allOf[1];\n\n // Iterate through the schema elements and add those to the inputSchema as Zod types\n for (\n const [key, schema] of Object.entries(requestSchema?.properties || {})\n ) {\n inputSchema[key] = createZodSchema(schema);\n }\n\n return {\n description: operation.description || operation.summary ||\n \"No description available\",\n inputSchema,\n };\n}\n\nfunction createZodSchema(schema: SchemaObject): z.ZodTypeAny {\n // if the type of this schema is an object then recursively create a zod schema for each property\n let property: z.ZodTypeAny;\n const properties: Record = {};\n switch (schema.type) {\n case \"object\":\n for (const [key, schm] of Object.entries(schema.properties)) {\n properties[key] = createZodSchema(schm);\n }\n return z.object(properties);\n case \"array\":\n property = z.array(createZodSchema(schema.items));\n break;\n case \"string\":\n property = z.string();\n break;\n case \"number\":\n property = z.number();\n break;\n case \"boolean\":\n property = z.boolean();\n break;\n default:\n return z.object({});\n }\n\n if (schema.default) {\n property.default(schema.default);\n }\n\n return property;\n}\n","deleted","label",[168,149],"src","permalink","https://www.val.town/x/supagroova/LiveStormMCP/code/src/mcp.ts","extension","actionData","errors"]