[{"_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","158b2c0451f0ab988546a26bbdbcac8ac7fa9322","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","c15r","name","Chat","path","frontend/utils/mcpClientPool.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","7e24160a-3cdc-11f0-aa89-9e149126039e","createdAt",["D",1748557815516],"deletedAt","legacyEnvVars","privacy","public","description","imageUrl","21f2e37e-8066-4730-9dc7-d27cf8d3c9f3","pinnedFileId","pinPreview","screenshotVersion","likeCount","0630d977-f678-453e-926c-52043293f59f","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm",{"_93":94,"_127":128},"profileImageUrl","https://img.clerk.com/eyJ0eXBlIjoicHJveHkiLCJzcmMiOiJodHRwczovL2ltYWdlcy5jbGVyay5kZXYvb2F1dGhfZ2l0aHViL2ltZ18yb2RJNlc1czZ1NlpZRmoxdGJ2eFVNNVhmeTYifQ","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",1417,"7e246fe2-3cdc-11f0-aa89-9e149126039e","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":32,"_160":161,"_162":163,"_164":20,"_165":-5,"_97":166},"26c02dd4-4ba2-11f0-9dfc-76b3cceeab13","mcpClientPool.ts","fileId","26c02e88-4ba2-11f0-9dfc-76b3cceeab13","parentId","f198e4e8-31a8-4644-b84e-c05e0c6281c1","branchId","branchVersion",777,"latest",true,["D",1750182025531],"fileType","script","content","/**\n * Centralized MCP Client Pool Utility\n * \n * Provides a unified interface for all MCP operations using existing client connections.\n * Eliminates duplicate client creation and connection logic across the application.\n */\n\nimport type { MCPServerConfig } from \"../../shared/types.ts\";\nimport { MCPClient } from \"./MCPClient.ts\";\n\nexport interface MCPTestResult {\n success: boolean;\n message?: string;\n error?: string;\n status?: number;\n}\n\nexport interface MCPTool {\n name: string;\n description?: string;\n serverName: string;\n serverId: string;\n inputSchema?: any;\n}\n\nexport interface MCPPrompt {\n name: string;\n description?: string;\n serverName: string;\n serverId: string;\n arguments?: Array<{\n name: string;\n description?: string;\n required?: boolean;\n }>;\n}\n\nexport interface MCPToolsResult {\n success: boolean;\n tools: MCPTool[];\n error?: string;\n}\n\nexport interface MCPPromptsResult {\n success: boolean;\n prompts: MCPPrompt[];\n error?: string;\n}\n\n/**\n * Centralized MCP Client Pool\n * Provides unified access to MCP operations using existing client connections\n */\nexport class MCPClientPool {\n constructor(\n private clients: MCPClient[],\n private serverConfigs: MCPServerConfig[] = []\n ) {}\n\n /**\n * Find client by server name with multiple matching strategies\n */\n findByName(serverName: string): MCPClient | null {\n if (!serverName) {\n console.warn(\"[MCPClientPool] No server name provided, trying first available client\");\n return this.clients[0] || null;\n }\n\n // Try multiple ways to match the server name\n const client = this.clients.find(client => {\n // Check serverInfo.name (from MCP initialization)\n if ((client as any).serverInfo?.name === serverName) {\n return true;\n }\n // Check clientInfo.name (fallback)\n if ((client as any).clientInfo?.name === serverName) {\n return true;\n }\n // Check if serverName matches any part of the client info\n const clientStr = JSON.stringify(client).toLowerCase();\n if (clientStr.includes(serverName.toLowerCase())) {\n return true;\n }\n return false;\n });\n\n if (!client) {\n console.warn(`[MCPClientPool] MCP server \"${serverName}\" not found in clients:`, \n this.clients.map(c => ({ \n serverInfo: (c as any).serverInfo, \n clientInfo: (c as any).clientInfo \n }))\n );\n }\n\n return client || null;\n }\n\n /**\n * Find client by server ID\n */\n findById(serverId: string): MCPClient | null {\n const config = this.serverConfigs.find(s => s.id === serverId);\n if (!config) return null;\n return this.findByName(config.name);\n }\n\n /**\n * Get all connected clients\n */\n getConnectedClients(): MCPClient[] {\n return this.clients.filter(client => \n client.isInitialized && client.isInitialized()\n );\n }\n\n /**\n * Test server connectivity using existing client\n */\n async testServer(serverName: string): Promise {\n const client = this.findByName(serverName);\n \n if (!client) {\n return {\n success: false,\n error: `No client available for server \"${serverName}\"`\n };\n }\n\n try {\n // Test basic connectivity by checking if client is initialized\n if (!client.isInitialized()) {\n return {\n success: false,\n error: \"Client not initialized\"\n };\n }\n\n // Try a simple operation to verify connectivity\n await client.listTools().catch(() => []); // Don't fail if tools aren't supported\n \n return {\n success: true,\n message: \"Server responding successfully\"\n };\n } catch (error) {\n return {\n success: false,\n error: error instanceof Error ? error.message : String(error)\n };\n }\n }\n\n /**\n * Fetch tools from all connected servers\n */\n async fetchTools(): Promise {\n try {\n const connectedClients = this.getConnectedClients();\n \n if (connectedClients.length === 0) {\n return {\n success: true,\n tools: []\n };\n }\n\n const toolPromises = connectedClients.map(async (client) => {\n try {\n const serverName = (client as any).serverInfo?.name || \n (client as any).clientInfo?.name || \n \"Unknown\";\n \n const tools = await client.listTools();\n return tools.map((tool: any) => ({\n name: tool.name,\n description: tool.description,\n serverName,\n serverId: serverName, // Use serverName as ID for now\n inputSchema: tool.inputSchema,\n }));\n } catch (error) {\n console.warn(`[MCPClientPool] Failed to fetch tools from client:`, error);\n return [];\n }\n });\n\n const toolArrays = await Promise.all(toolPromises);\n const allTools = toolArrays.flat();\n\n return {\n success: true,\n tools: allTools\n };\n } catch (error) {\n return {\n success: false,\n tools: [],\n error: error instanceof Error ? error.message : String(error)\n };\n }\n }\n\n /**\n * Fetch prompts from all connected servers\n */\n async fetchPrompts(): Promise {\n try {\n const connectedClients = this.getConnectedClients();\n \n if (connectedClients.length === 0) {\n return {\n success: true,\n prompts: []\n };\n }\n\n const promptPromises = connectedClients.map(async (client) => {\n try {\n const serverName = (client as any).serverInfo?.name || \n (client as any).clientInfo?.name || \n \"Unknown\";\n \n const prompts = await client.listPrompts();\n return prompts.map((prompt: any) => ({\n name: prompt.name,\n description: prompt.description,\n serverName,\n serverId: serverName, // Use serverName as ID for now\n arguments: prompt.arguments,\n }));\n } catch (error) {\n console.warn(`[MCPClientPool] Failed to fetch prompts from client:`, error);\n return [];\n }\n });\n\n const promptArrays = await Promise.all(promptPromises);\n const allPrompts = promptArrays.flat();\n\n // Add a test prompt for development/testing purposes\n const testPrompt: MCPPrompt = {\n name: \"test\",\n description: \"Testing the system\",\n serverName: \"Built-in\",\n serverId: \"builtin\",\n arguments: [{\n name: \"subsystem\",\n description: \"Sub system to test\",\n required: false,\n }],\n };\n\n return {\n success: true,\n prompts: [testPrompt, ...allPrompts]\n };\n } catch (error) {\n return {\n success: false,\n prompts: [],\n error: error instanceof Error ? error.message : String(error)\n };\n }\n }\n\n /**\n * Call a tool on a specific server\n */\n async callTool(serverName: string, toolName: string, args: any): Promise {\n const client = this.findByName(serverName);\n \n if (!client) {\n throw new Error(`No client available for server \"${serverName}\"`);\n }\n\n return await client.callTool(toolName, args);\n }\n\n /**\n * Get a prompt from a specific server\n */\n async getPrompt(serverName: string, promptName: string, args?: Record): Promise {\n const client = this.findByName(serverName);\n \n if (!client) {\n throw new Error(`No client available for server \"${serverName}\"`);\n }\n\n return await client.getPrompt(promptName, args);\n }\n\n /**\n * Read a resource from a specific server\n */\n async readResource(serverName: string, uri: string): Promise {\n const client = this.findByName(serverName);\n \n if (!client) {\n throw new Error(`No client available for server \"${serverName}\"`);\n }\n\n return await client.readResource(uri);\n }\n\n /**\n * List resources from all connected servers\n */\n async listResources(): Promise {\n const connectedClients = this.getConnectedClients();\n const allResources = [];\n\n for (const client of connectedClients) {\n try {\n const resources = await client.listResources();\n const serverName = (client as any).serverInfo?.name || \"Unknown\";\n \n allResources.push(...resources.map((resource: any) => ({\n ...resource,\n serverName,\n })));\n } catch (error) {\n console.warn(`[MCPClientPool] Failed to list resources from client:`, error);\n }\n }\n\n return allResources;\n }\n\n /**\n * Get server status information for debugging\n */\n getServerStatuses(): Array<{\n serverName: string;\n isConnected: boolean;\n capabilities?: any;\n serverInfo?: any;\n clientInfo?: any;\n }> {\n return this.clients.map(client => ({\n serverName: (client as any).serverInfo?.name || \n (client as any).clientInfo?.name || \n \"Unknown\",\n isConnected: client.isInitialized ? client.isInitialized() : false,\n capabilities: (client as any).capabilities,\n serverInfo: (client as any).serverInfo,\n clientInfo: (client as any).clientInfo,\n }));\n }\n\n /**\n * Update the client pool with new clients\n */\n updateClients(clients: MCPClient[], serverConfigs: MCPServerConfig[] = []): MCPClientPool {\n return new MCPClientPool(clients, serverConfigs);\n }\n}","deleted","label",[167,168,149],"frontend","utils","permalink","https://www.val.town/x/c15r/Chat/code/frontend/utils/mcpClientPool.ts","extension","actionData","errors"]