Simple MCP Client

\n\n \n \n \n \n \n Test MCP Server\n \n \n\n

\n \n ,\n ));\n\n// API endpoint to test MCP with streaming\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 const mcpClient = await createMcpClient({\n transport: new StreamableHTTPClientTransport(new URL(url)),\n });\n\n const tools = await mcpClient.tools();\n\n const result = await streamText({\n model: \"gpt-4o\",\n prompt,\n tools,\n });\n\n return result.toDataStreamResponse();\n});\n\nexport default app.fetch;","mcp-client-po",[],[151,171],{"_103":181,"_95":182,"_152":183,"_154":153,"_155":137,"_156":184,"_158":159,"_105":185,"_100":186,"_162":175,"_164":187,"_165":22,"_166":188,"_167":189,"_98":190},"b636a690-43b5-11f0-a26c-76b3cceeab13","openapi.tsx","416a49e6-3700-11f0-b6d5-9e149126039e",456,["D",1749310817357],19,"/** @jsxImportSource https://esm.sh/react@18.2.0 */\n\nimport { createRoute, OpenAPIHono } from \"https://esm.sh/@hono/zod-openapi@0.9.6?deps=hono@3.11.7\";\nimport { Hono } from \"https://esm.sh/hono@3.11.7\";\nimport { jsxRenderer } from \"https://esm.sh/hono@3.11.7/jsx-renderer\";\nimport { z } from \"https://esm.sh/zod@3.22.4\";\nimport { SSEEdgeClientTransport } from \"./sse.ts\";\n\nconst app = new OpenAPIHono();\n\n// UI: HTML test page\napp.get(\"/\", (c) =>\n c.html(\n \n \n Simple MCP Client\n \n \n \n \n

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;","mcp-api",[],[151,182],{"_103":192,"_95":193,"_152":194,"_154":153,"_155":137,"_156":195,"_158":159,"_105":196,"_100":197,"_162":198,"_164":199,"_165":22,"_166":-5,"_167":200,"_98":201},"51801c1c-43b6-11f0-8354-76b3cceeab13","sse.ts","8b3ecc10-43b5-11f0-ac46-76b3cceeab13",460,["D",1749311077883],4,"script","import type { OAuthClientProvider } from \"npm:@modelcontextprotocol/sdk/client/auth.js\";\nimport { SSEClientTransport, type SSEClientTransportOptions } from \"npm:@modelcontextprotocol/sdk/client/sse.js\";\n\nexport class SSEEdgeClientTransport extends SSEClientTransport {\n private authProvider: OAuthClientProvider | undefined;\n /**\n * Creates a new EdgeSSEClientTransport, which overrides fetch to be compatible with the CF workers environment\n */\n constructor(url: URL, options: SSEClientTransportOptions = {}) {\n const fetchOverride: typeof fetch = async (\n fetchUrl: RequestInfo | URL,\n fetchInit: RequestInit = {},\n ) => {\n options = options || {};\n // add auth headers\n const headers = await this.authHeaders();\n const workerOptions = {\n ...fetchInit,\n headers: {\n ...options?.requestInit?.headers,\n ...fetchInit?.headers,\n ...headers,\n },\n };\n\n // Remove unsupported properties\n // biome-ignore lint/performance/noDelete: workaround for workers environment\n delete workerOptions.mode;\n\n // Call the original fetch with fixed options\n return (\n (options.eventSourceInit?.fetch?.(\n fetchUrl as URL | string,\n // @ts-expect-error Expects FetchLikeInit from EventSource but is compatible with RequestInit\n workerOptions,\n ) as Promise) || fetch(fetchUrl, workerOptions)\n );\n };\n\n super(url, {\n ...options || {},\n eventSourceInit: {\n ...options?.eventSourceInit || {},\n fetch: fetchOverride,\n },\n });\n this.authProvider = options?.authProvider;\n }\n\n async authHeaders() {\n if (this.authProvider) {\n const tokens = await this.authProvider.tokens();\n if (tokens) {\n return {\n Authorization: `Bearer ${tokens.access_token}`,\n };\n }\n }\n }\n}",[],[151,193],[151],{"_103":204,"_95":205,"_152":206,"_154":-5,"_155":137,"_156":207,"_158":159,"_105":208,"_100":161,"_162":163,"_164":-5,"_165":22,"_166":-5,"_167":209,"_98":221},"53c05b10-36fd-11f0-a145-9e149126039e","servers","50d627fe-36fd-11f0-a45b-9e149126039e",375,["D",1747912210817],[210],{"_103":211,"_95":212,"_152":213,"_154":206,"_155":137,"_156":214,"_158":159,"_105":215,"_100":216,"_162":175,"_164":217,"_165":22,"_166":218,"_167":219,"_98":220},"f0166b1e-4457-11f0-81d6-76b3cceeab13","store.ts","7c8887ce-3339-11f0-b173-9e149126039e",478,["D",1749380492924],146,"import { blob } from \"https://esm.town/v/std/blob\";\nimport { createMcpHandler } from \"npm:@vercel/mcp-adapter@0.4.1\";\nimport { z } from \"npm:zod\";\n\n// Import tools\nimport type { McpServer } from \"npm:@modelcontextprotocol/sdk/server/mcp.js\";\n\nconst getChannelKey = (channel: string): string => `channel:${channel}`;\n\nconst handler = createMcpHandler(\n (server: McpServer) => {\n const listTool = server.tool(\n \"listMessages\",\n { channel: z.string() },\n async function({ channel }) {\n console.log(channel);\n const messages = await blob.list(getChannelKey(channel));\n console.log(\"messages\", messages);\n\n const content = await Promise.all(messages.map(async ({ key }) => {\n const message = await blob.getJSON(key);\n console.log(\"message\", message);\n return message;\n }));\n\n return {\n content: [{ type: \"text\", text: content.join(\"\\n\") }],\n };\n },\n );\n const listUserTools = server.tool(\n \"listUserMessages\",\n async function({ sessionId, authInfo }) {\n console.log(authInfo, sessionId);\n const messages = await blob.list(getChannelKey(sessionId));\n console.log(\"messages\", messages);\n\n const content = await Promise.all(messages.map(async ({ key }) => {\n const message = await blob.getJSON(key);\n console.log(\"message\", message);\n return message;\n }));\n\n return {\n content: [{ type: \"text\", text: content.join(\"\\n\") }],\n };\n },\n );\n const putUserTool = server.tool(\n \"putUserMessage\",\n { message: z.string() },\n async function({ message }: { message: string }, { sessionId: channel, authInfo }) {\n console.log(\"putUserMessage\", channel, message, authInfo);\n\n const key = getChannelKey(channel);\n const messages = await blob.list(getChannelKey(channel));\n await blob.setJSON(`${key}:${messages.length}`, message);\n return {\n content: [{ type: \"text\", text: `Message added to channel ${channel}` }],\n };\n },\n );\n const putTool = server.tool(\n \"putMessage\",\n { channel: z.string(), message: z.string() },\n async function({ channel, message }: { channel: string; message: string }) {\n console.log(\"putMessage\", channel, message);\n\n const key = getChannelKey(channel);\n const messages = await blob.list(getChannelKey(channel));\n await blob.setJSON(`${key}:${messages.length}`, message);\n return {\n content: [{ type: \"text\", text: `Message added to channel ${channel}` }],\n };\n },\n );\n server.tool(\"whoami\", ({ sessionId, authInfo }) => {\n console.log(\"authInfo\", authInfo);\n return {\n content: [\n { type: \"text\", text: JSON.stringify(authInfo ?? { error: \"Not authenticated\" }) },\n ],\n };\n });\n server.prompt(\n \"messages\",\n { channel: z.string() },\n ({ channel }) => ({\n messages: [{\n role: \"user\",\n content: {\n type: \"text\",\n text: `find messages in channel ${channel} }`,\n },\n }],\n }),\n );\n\n server.prompt(\n \"test-prompt\",\n { arg: z.string() },\n ({ arg }) => ({\n messages: [{\n role: \"user\",\n content: {\n type: \"text\",\n text: `Say this is a test:\\n\\n${arg}`,\n },\n }],\n }),\n );\n\n server.resource(\n \"schema\",\n \"schema://main\",\n async (uri) => {\n return {\n contents: [{\n uri: uri.href,\n text: \"test-content\",\n }],\n };\n },\n );\n // server.resource(\n // \"greeting\",\n // new ResourceTemplate(\"greeting://{name}\", { list: undefined }),\n // async (uri, { name }) => ({\n // contents: [{\n // uri: uri.href,\n // text: `Hello, ${name}!`,\n // }],\n // }),\n // );\n },\n {\n redisUrl: Deno.env.get(\"REDIS_URL\"),\n verboseLogs: true,\n maxDuration: 60,\n },\n);\n\nexport default handler;","store-mcp",[],[205,212],[205],{"_103":223,"_95":224,"_152":225,"_154":-5,"_155":137,"_156":226,"_158":159,"_105":227,"_100":161,"_162":228,"_164":229,"_165":22,"_166":-5,"_167":230,"_98":231},"a2d2e3c0-3339-11f0-bd07-9e149126039e","README.md","ab125e4c-32e6-11f0-a4e8-569c3dd06744",51,["D",1747498308627],"file","# MCP Server Manager\n\nThis is an HTTP handler that serves as an MCP (Model Control Protocol) server with tools to create and manage structured MCP server projects.\n\n## Features\n\n- Create new MCP server projects with a structured file organization\n- Add new tools to existing MCP server projects\n- Update files in MCP server projects\n- Get template code for MCP server files\n\n## Project Structure\n\nThis MCP server manager follows this structure:\n\n```\nproject/\n├── main.tsx # Main entry point with MCP handler\n├── tools/\n│ ├── create-mcp-project.ts # Tool to create new MCP projects\n│ ├── add-tool-to-project.ts # Tool to add tools to projects\n│ ├── update-project-file.ts # Tool to update project files\n│ └── get-mcp-templates.ts # Tool to get MCP templates\n└── resources/\n ├── mcp-templates.ts # Templates for MCP server files\n └── val-town-api.ts # Val Town API utilities\n```\n\nEach MCP server project created by this tool follows this structure:\n\n```\nproject/\n├── main.tsx # Main entry point with MCP handler\n└── tools/\n ├── echo.ts # Default echo tool\n └── [toolName].ts # Additional tools\n```\n\n## Tools\n\n### 1. create_mcp_project\n\nCreates a new MCP server project with a structured file organization.\n\nParameters:\n- `name`: Name of the project to create\n- `description`: Description of the project\n\n### 2. add_tool_to_project\n\nAdds a new tool to an existing MCP server project.\n\nParameters:\n- `projectId`: ID of the project to update\n- `toolName`: Name of the tool to add\n- `toolDescription`: Description of the tool\n- `inputSchema`: Input schema for the tool (e.g., `{\"message\": \"z.string().describe(\\\"Message to process\\\")\"}`\n\n### 3. update_project_file\n\nUpdates a file in an MCP server project.\n\nParameters:\n- `projectId`: ID of the project\n- `filePath`: Path of the file to update\n- `content`: New content for the file\n\n### 4. get_mcp_templates\n\nGets the MCP server template code for various files.\n\nParameters:\n- `templateType`: Type of template to get (main or tool)\n\n## Setup Requirements\n\nThis val requires the following environment variables:\n- `VAL_TOWN_API_KEY`: Your Val Town API key for creating and updating projects\n- `REDIS_URL`: Redis URL for the MCP server (used by @vercel/mcp-adapter)\n\n## Usage\n\nThis val is designed to be used as an MCP server endpoint that can be connected to by AI assistants that support the MCP protocol. The assistant can then use the provided tools to create and manage MCP server projects with a structured approach.\n\n## File Templates\n\n### main.tsx\n\nThe main entry point for the MCP server that imports and registers all tools.\n\n### tools/[toolName].ts\n\nEach tool is defined in its own file with a consistent structure including:\n- Name\n- Description\n- Input schema\n- Handler function",[],[224],"files",[149,169,180,191,203,210,222],"counts",{"_236":32,"_237":161,"_238":32,"_239":240},"pulls","branches","forks","envVars",18,"contents",[],{"_103":170,"_95":171,"_152":172,"_154":153,"_155":137,"_156":136,"_158":159,"_105":244,"_100":174,"_162":175,"_164":176,"_165":22,"_166":177,"_98":245},["D",1755870398632],[151,171],"upstreamProject","upstreamBranch","emptyEnvVars","isNew","flags",[],"routes/_app.x.$handle.$name.branch.$branch.code.$",{"_93":94,"_95":96,"_97":43,"_100":-7,"_98":99,"_101":254,"_147":259,"_232":281,"_228":282,"_241":284,"_285":-5,"_286":22,"_287":-5,"_288":-5,"_289":-5,"_290":291},{"_103":104,"_95":96,"_105":255,"_107":-5,"_108":22,"_109":110,"_111":-5,"_112":-5,"_14":113,"_114":-5,"_115":22,"_116":-5,"_117":32,"_16":118,"_119":120,"_121":120,"_122":123,"_124":123,"_125":123,"_126":120,"_127":120,"_23":256,"_131":257,"_134":258,"_146":22},["D",1747457599190],{"_93":94,"_129":130},{"_93":94,"_133":130},{"_100":136,"_95":43,"_103":137,"_138":104,"_139":-5,"_140":-5,"_141":-5,"_142":-5,"_143":-5,"_144":96,"_145":94},[260,272,278],{"_103":150,"_95":151,"_152":153,"_154":-5,"_155":137,"_156":157,"_158":159,"_105":160,"_100":161,"_162":163,"_164":-5,"_165":22,"_166":-5,"_167":261,"_98":271},[262,265,268],{"_103":170,"_95":171,"_152":172,"_154":153,"_155":137,"_156":136,"_158":159,"_105":173,"_100":174,"_162":175,"_164":176,"_165":22,"_166":177,"_167":263,"_98":264},[],[151,171],{"_103":181,"_95":182,"_152":183,"_154":153,"_155":137,"_156":184,"_158":159,"_105":185,"_100":186,"_162":175,"_164":187,"_165":22,"_166":188,"_167":266,"_98":267},[],[151,182],{"_103":192,"_95":193,"_152":194,"_154":153,"_155":137,"_156":195,"_158":159,"_105":196,"_100":197,"_162":198,"_164":199,"_165":22,"_166":-5,"_167":269,"_98":270},[],[151,193],[151],{"_103":204,"_95":205,"_152":206,"_154":-5,"_155":137,"_156":207,"_158":159,"_105":208,"_100":161,"_162":163,"_164":-5,"_165":22,"_166":-5,"_167":273,"_98":277},[274],{"_103":211,"_95":212,"_152":213,"_154":206,"_155":137,"_156":214,"_158":159,"_105":215,"_100":216,"_162":175,"_164":217,"_165":22,"_166":218,"_167":275,"_98":276},[],[205,212],[205],{"_103":223,"_95":224,"_152":225,"_154":-5,"_155":137,"_156":226,"_158":159,"_105":227,"_100":161,"_162":228,"_164":229,"_165":22,"_166":-5,"_167":279,"_98":280},[],[224],[260,262,265,268,272,274,278],{"_103":170,"_95":171,"_152":172,"_154":153,"_155":137,"_156":136,"_158":159,"_105":244,"_100":174,"_162":175,"_164":176,"_165":22,"_166":177,"_98":283},[151,171],[],"upstream","showCompareCallout","pull","ahead","behind","templates",[],"actionData","errors"]