Simple MCP Client

\n \n ,\n ));\n\n// Stream prompt with tools\napp.post(\"/test\", async (c) => {\n const body = await c.req.parseBody();\n const url = body.url as string;\n const prompt = body.prompt as string;\n\n try {\n // Create a simplified MCP client\n const transport = new SSEEdgeClientTransport(new URL(url));\n\n // Fetch tools from the MCP server\n const toolsResponse = await transport.fetch(\"/tools\");\n const tools = await toolsResponse.json();\n\n // Return a simple response for now since we can't use streamText\n return c.json({\n message: \"MCP client initialized successfully\",\n prompt,\n availableTools: Object.keys(tools || {}),\n });\n } catch (error) {\n return c.text(`Error: ${error.message}`, 500);\n }\n});\n\n// Dynamic OpenAPI endpoint\napp.get(\"/dynamic-openapi.json\", async (c) => {\n const url = c.req.query(\"url\");\n if (!url) return c.text(\"Missing URL\", 400);\n\n try {\n const transport = new SSEEdgeClientTransport(new URL(url));\n const toolsResponse = await transport.fetch(\"/tools\");\n const tools = await toolsResponse.json();\n\n const paths = {};\n for (const [toolName, toolDef] of Object.entries(tools)) {\n // zod schema handling (simple fallback)\n const inputZod = toolDef.inputSchema || z.any();\n const outputZod = toolDef.outputSchema || z.any();\n paths[`/${toolName}`] = {\n post: {\n summary: toolDef.description,\n requestBody: {\n content: {\n \"application/json\": {\n schema: inputZod, // optionally use zodToOpenAPI(inputZod)\n },\n },\n },\n responses: {\n \"200\": {\n description: \"Result\",\n content: {\n \"application/json\": {\n schema: outputZod, // optionally use zodToOpenAPI(outputZod)\n },\n },\n },\n },\n },\n };\n }\n const openapi = {\n openapi: \"3.1.0\",\n info: {\n title: \"Dynamic MCP OpenAPI\",\n version: \"1.0.0\",\n },\n paths,\n };\n // Pretty print\n return c.html(`

${JSON.stringify(openapi, null, 2)}

`);\n } catch (err) {\n return c.text(`Error: ${err.message}`, 500);\n }\n});\n\n// Generic MCP client for accessing tools, resources, and execution\napp.get(\"/tools\", async (c) => {\n const url = c.req.query(\"url\");\n if (!url) return c.text(\"Missing URL\", 400);\n\n try {\n const transport = new SSEEdgeClientTransport(new URL(url));\n const toolsResponse = await transport.fetch(\"/tools\");\n const tools = await toolsResponse.json();\n return c.json(tools);\n } catch (err) {\n return c.text(`Error: ${err.message}`, 500);\n }\n});\n\napp.get(\"/resources\", async (c) => {\n const url = c.req.query(\"url\");\n if (!url) return c.text(\"Missing URL\", 400);\n\n try {\n const transport = new SSEEdgeClientTransport(new URL(url));\n const resourcesResponse = await transport.fetch(\"/resources\");\n const resources = await resourcesResponse.json();\n return c.json(resources);\n } catch (err) {\n return c.text(`Error: ${err.message}`, 500);\n }\n});\n\napp.post(\"/execute\", async (c) => {\n const { url, toolName, args } = await c.req.json();\n if (!url || !toolName) return c.text(\"Missing url or tool name\", 400);\n\n try {\n const transport = new SSEEdgeClientTransport(new URL(url));\n const response = await transport.fetch(`/tools/${toolName}`, {\n method: \"POST\",\n headers: {\n \"Content-Type\": \"application/json\",\n },\n body: JSON.stringify(args || {}),\n });\n const result = await response.json();\n return c.json(result);\n } catch (err) {\n return c.text(`Error: ${err.message}`, 500);\n }\n});\n\n// OpenAPI route dynamically generating from schema\napp.openapi(\n createRoute({\n method: \"post\",\n path: \"/execute\",\n description: \"Execute a tool from MCP server dynamically\",\n request: {\n body: z.object({\n url: z.string().url(),\n toolName: z.string(),\n args: z.record(z.any()).optional(),\n }),\n },\n responses: {\n 200: {\n description: \"Execution result\",\n content: {\n \"application/json\": {\n schema: z.any(),\n },\n },\n },\n },\n }),\n async (c) => {\n const { url, toolName, args } = await c.req.json();\n const transport = new SSEEdgeClientTransport(new URL(url));\n const response = await transport.fetch(`/tools/${toolName}`, {\n method: \"POST\",\n headers: {\n \"Content-Type\": \"application/json\",\n },\n body: JSON.stringify(args || {}),\n });\n const result = await response.json();\n return c.json(result);\n },\n);\n\napp.doc(\"/openapi.json\", {\n openapi: \"3.1.0\",\n info: {\n title: \"MCP Client API\",\n version: \"1.0.0\",\n },\n});\n\nexport default app.fetch;","deleted","label","mcp-api",[169,149],"clients","permalink","https://www.val.town/x/dinavinter/mcp/code/clients/openapi.tsx","extension","actionData","errors"]