Server Test Client

\n\n

Test MCP Server

\n Prompt:\n \n

\n \n

Response:

Response will appear here...

\n\n

Test Server Endpoints

Home

SSE

Tools

\n Endpoint:\n \n

\n Method:\n \n

\n Request Body (for POST/PUT):\n \n \n

\n \n

Response:

Response will appear here...

\n\n

\n \n View Source\n \n

\n\n \n \n ,\n );\n});\n\n// API endpoint to test MCP\napp.post(\"/api/mcp-test\", async (c) => {\n try {\n const { prompt } = await c.req.json();\n\n const mcpClient = await createClient();\n const tools = await mcpClient.tools();\n\n const { text } = await generateText({\n model: azure(\"gpt-4o\"),\n prompt: prompt || \"Hello, world!\",\n tools: {\n ...tools,\n },\n });\n\n return c.json({ text });\n } catch (error) {\n console.error(\"MCP Test Error:\", error);\n return c.json({ error: error.message }, 500);\n }\n});\n\n// API endpoint to proxy requests to the server\napp.post(\"/api/proxy\", async (c) => {\n try {\n const { endpoint, method, body } = await c.req.json();\n\n const url = `${SERVER_URL}${endpoint}`;\n const options: RequestInit = {\n method,\n headers: {\n \"Content-Type\": \"application/json\",\n \"Authorization\": `Bearer ${Deno.env.get(\"AUTH_TOKEN\") || \"YOUR TOKEN HERE\"}`,\n },\n };\n\n if (method === \"POST\" || method === \"PUT\") {\n options.body = JSON.stringify(body);\n }\n\n const response = await fetch(url, options);\n const contentType = response.headers.get(\"Content-Type\") || \"\";\n\n if (contentType.includes(\"application/json\")) {\n const data = await response.json();\n return c.json(data, response.status);\n } else {\n const text = await response.text();\n return c.text(text, response.status);\n }\n } catch (error) {\n console.error(\"Proxy Error:\", error);\n return c.json({ error: error.message }, 500);\n }\n});\n\n// Export the Hono app as the default handler for HTTP requests\nexport default app.fetch;","mcp-client-po",[],[260],{"_104":270,"_95":271,"_153":272,"_155":-5,"_156":138,"_157":273,"_159":22,"_106":274,"_100":275,"_162":176,"_164":276,"_165":22,"_166":-5,"_167":277,"_98":278},"28626adc-33db-11f0-a5c1-9e149126039e","dynamic.ts","ff3b777e-33d1-11f0-8a3b-9e149126039e",290,["D",1747567681681],19,"import { sqlite } from \"https://esm.town/v/std/sqlite\";\nimport { McpServer } from \"npm:@modelcontextprotocol/sdk/server/mcp.js\";\nimport ValTown, { type RequestOptions } from \"npm:@valtown/sdk\";\nimport { z } from \"npm:zod\";\n\n// Create messages table if it doesn't exist\nasync function ensureMessagesTable() {\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS messages (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n channel TEXT NOT NULL,\n message TEXT NOT NULL,\n created_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP\n )\n `);\n}\n\n// Initialize the table\nensureMessagesTable();\n\n// Store authentication tokens with their permission levels\nconst AUTH_TOKEN_KEY = \"auth_token\";\nlet currentPermission = \"read\"; // Default to read-only\n\nfunction listMessages(channel: string) {\n return sqlite\n .execute({ sql: \"SELECT message FROM messages WHERE channel = :channel ORDER BY id DESC\", args: { channel } })\n .then((result) => result.rows.map((row) => row.message).join(\"\\n\"));\n}\n\nfunction putMessage(channel: string, message: string) {\n return sqlite\n .execute({ sql: \"INSERT INTO messages (channel, message) VALUES (:channel, :message)\", args: { channel, message } })\n .then(() => `Message added to channel ${channel}`);\n}\n\n// Function to upgrade authentication and store token\nasync function upgradeAuthAndStoreToken(permission: \"write\" | \"admin\") {\n try {\n // In a real implementation, this would validate the token with Val Town API\n // For this example, we'll simulate the upgrade\n const previous = currentPermission;\n currentPermission = permission;\n\n // Store the token in a real implementation\n // await blob.setJSON(AUTH_TOKEN_KEY, { permission, token: \"simulated-token\" });\n\n return { ok: true, err: null, previous };\n } catch (error) {\n return { ok: false, err: error instanceof Error ? error.message : String(error), previous: currentPermission };\n }\n}\n\nexport default function(server: McpServer) {\n const listMessageTool = server.tool(\n \"listMessages\",\n { channel: z.string() },\n async ({ channel }) => ({\n content: [{ type: \"text\", text: await listMessages(channel) }],\n }),\n );\n\n const putMessageTool = server.tool(\n \"putMessage\",\n { channel: z.string(), message: z.string() },\n async ({ channel, message }) => ({\n content: [{ type: \"text\", text: await putMessage(channel, message) }],\n }),\n );\n // Until we upgrade auth, `putMessage` is disabled (won't show up in listTools)\n putMessageTool.disable();\n\n const upgradeAuthTool = server.tool(\n \"upgradeAuth\",\n { permission: z.enum([\"write\", \"admin\"]) },\n // Any mutations here will automatically emit `listChanged` notifications\n async ({ permission }) => {\n const { ok, err, previous } = await upgradeAuthAndStoreToken(permission);\n if (!ok) return { content: [{ type: \"text\", text: `Error: ${err}` }] };\n\n // If we previously had read-only access, 'putMessage' is now available\n if (previous === \"read\") {\n putMessageTool.enable();\n }\n\n if (permission === \"write\") {\n putMessageTool.enable();\n // If we've just upgraded to 'write' permissions, we can still call 'upgradeAuth'\n // but can only upgrade to 'admin'.\n upgradeAuthTool.update({\n paramSchema: { permission: z.enum([\"admin\"]) }, // change validation rules\n });\n } else {\n // If we're now an admin, we no longer have anywhere to upgrade to, so fully remove that tool\n upgradeAuthTool.remove();\n }\n\n return {\n content: [{\n type: \"text\",\n text: `Successfully upgraded permissions from '${previous}' to '${permission}'`,\n }],\n };\n },\n );\n}",[],[271],{"_104":280,"_95":281,"_153":282,"_155":-5,"_156":138,"_157":283,"_159":22,"_106":284,"_100":285,"_162":264,"_164":286,"_165":22,"_166":287,"_167":288,"_98":289},"2eab3084-34b4-11f0-a6f5-9e149126039e","main.tsx","7c8887ce-3339-11f0-b173-9e149126039e",316,["D",1747660893014],60,"import { createMcpHandler } from \"npm:@vercel/mcp-adapter\";\nimport { z } from \"npm:zod\";\n// console.log(Deno.env.get(\"REDIS_URL\"));\n// Import tools\nimport type { McpServer } from \"npm:@modelcontextprotocol/sdk/server/mcp.js\";\nimport dynamic from \"./dynamic.ts\";\nimport registerServerTools from \"./mcp-server-tools.ts\";\nimport addToolToProjectTool from \"./tools/add-tool-to-project.ts\";\nimport createMcpProjectTool from \"./tools/create-mcp-project.ts\";\nimport getMcpTemplatesTool from \"./tools/get-mcp-templates.ts\";\nimport updateProjectFileTool from \"./tools/update-project-file.ts\";\nconst handler = createMcpHandler(\n (server: McpServer) => {\n function register(tool: { name: string; description: string; schema: z.Schema; handler: Function }) {\n server.tool(tool.name, tool.description, tool.schema, tool.handler);\n }\n // Register tools\n dynamic(server);\n // registerServerTools(server);\n // register(addToolToProjectTool);\n // register(updateProjectFileTool);\n register(getMcpTemplatesTool);\n },\n {\n redisUrl: Deno.env.get(\"REDIS_URL\"),\n verboseLogs: true,\n maxDuration: 60,\n },\n);\n\nexport default (request: Request) => {\n if (request.headers.get(\"Authorization\")?.replace(\"Bearer \", \"\") !== Deno.env.get(\"AUTH_TOKEN\")) {\n return new Response(\"Unauthorized\", { status: 401 });\n }\n\n return handler(request);\n};","store-mcp",[],[281],{"_104":291,"_95":292,"_153":293,"_155":-5,"_156":138,"_157":294,"_159":22,"_106":295,"_100":296,"_162":176,"_164":297,"_165":22,"_166":-5,"_167":298,"_98":299},"b8a3e936-33b8-11f0-bda8-9e149126039e","mcp-server-tools.ts","477de712-334e-11f0-8d41-9e149126039e",243,["D",1747552891317],50,"import { McpServer } from \"npm:@modelcontextprotocol/sdk/server/mcp.js\";\nimport ValTown, { type RequestOptions } from \"npm:@valtown/sdk\";\nimport { z } from \"npm:zod\";\n\nexport default function(server: McpServer, config: RequestOptions = {}) {\n const client = new ValTown({ bearerToken: Deno.env.get(\"VAL\")! });\n\n // List all servers\n server.tool(\n \"list-servers\",\n \"List all MCP servers accessible to the current user\",\n {\n limit: z.number().int().min(1).max(100).default(20).describe(\"Maximum number of results to return\"),\n offset: z.number().int().min(0).default(0).describe(\"Number of items to skip for pagination\"),\n },\n async ({ limit, offset }: { limit: number; offset: number }) => {\n try {\n const vals = await client.me.vals.list({\n limit: limit,\n offset: offset,\n }).then(e => e.data);\n\n return {\n content: [{ type: \"text\", text: JSON.stringify(vals, null, 2) }],\n };\n } catch (error) {\n console.error(error);\n const errorMessage = error instanceof Error ? error.message : String(error);\n return {\n content: [{ type: \"text\", text: `Error listing MCP servers: ${errorMessage}` }],\n isError: true,\n };\n }\n },\n );\n\n // Get a specific server\n server.tool(\n \"get-server\",\n \"Get details about a specific MCP server\",\n {\n serverId: z.string().describe(\"ID of the MCP server\"),\n },\n async ({ serverId }: { serverId: string }) => {\n try {\n const { data } = await client.vals.retrieve(serverId, config);\n\n return {\n content: [{ type: \"text\", text: JSON.stringify(data, null, 2) }],\n };\n } catch (error) {\n console.error(error);\n const errorMessage = error instanceof Error ? error.message : String(error);\n return {\n content: [{ type: \"text\", text: `Error getting MCP server: ${errorMessage}` }],\n isError: true,\n };\n }\n },\n );\n\n // Get a server by username and server name\n server.tool(\n \"get-server-by-name\",\n \"Get an MCP server by username and server name\",\n {\n name: z.string().describe(\"Name of the MCP server\"),\n },\n async ({ name }: { name: string }) => {\n try {\n // Check if CLI is available\n return await client.me.vals.list({\n limit: 100,\n offset: 0,\n ...config,\n }).then(res => res.data).then(files => files.find((z) => z.name === name));\n }\n // If CLI fails, fall back to API\n catch (error) {\n console.error(error);\n const errorMessage = error instanceof Error ? error.message : String(error);\n return {\n content: [{ type: \"text\", text: `Error getting MCP server: ${errorMessage}` }],\n isError: true,\n };\n }\n },\n );\n\n // Create a new MCP server\n server.tool(\n \"create-server\",\n \"Create a new MCP server\",\n {\n name: z.string()\n .regex(\n /^[a-zA-Z][a-zA-Z0-9_]*$/,\n \"Server name must start with a letter and can only contain letters, numbers, and underscores\",\n )\n .describe(\"Name for the MCP server\"),\n privacy: z.enum([\"public\", \"unlisted\", \"private\"]).default(\"unlisted\")\n .describe(\"Privacy setting: public, unlisted, or private\"),\n description: z.string().max(64).optional()\n .describe(\"Description for the MCP server (optional, max 64 characters)\"),\n imageUrl: z.string().url().optional().describe(\"URL to an image for the MCP server (optional)\"),\n },\n async ({ name, privacy, description, imageUrl }: {\n name: string;\n privacy: \"public\" | \"unlisted\" | \"private\";\n description?: string;\n imageUrl?: string;\n }) => {\n try {\n // Create payload with required and optional fields\n const payload = {\n name,\n privacy,\n ...(description !== undefined ? { description } : {}),\n ...(imageUrl !== undefined ? { imageUrl } : {}),\n };\n\n const response = await client.vals.create(payload, config);\n\n return {\n content: [{ type: \"text\", text: JSON.stringify(response, null, 2) }],\n };\n } catch (error) {\n console.error(error);\n const errorMessage = error instanceof Error ? error.message : String(error);\n return {\n content: [{ type: \"text\", text: `Error creating MCP server: ${errorMessage}` }],\n isError: true,\n };\n }\n },\n );\n}",[],[292],{"_104":301,"_95":302,"_153":303,"_155":-5,"_156":138,"_157":304,"_159":22,"_106":305,"_100":306,"_162":176,"_164":307,"_165":22,"_166":-5,"_167":308,"_98":309},"3645399a-34b2-11f0-ae12-9e149126039e","sse.ts","3a6f6ab4-34b1-11f0-9d62-9e149126039e",307,["D",1747660046774],9,"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 // 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}",[],[302],"files",[150,169,180,190,200,206,216,226,236,247,258,269,279,290,300],"counts",{"_314":32,"_315":161,"_316":32,"_317":318},"pulls","branches","forks","envVars",18,"contents",[321,324,327,330],{"_104":207,"_95":208,"_153":209,"_155":202,"_156":138,"_157":210,"_159":22,"_106":322,"_100":212,"_162":176,"_164":213,"_165":22,"_166":-5,"_98":323},["D",1747561202254],[99,208],{"_104":217,"_95":218,"_153":219,"_155":202,"_156":138,"_157":220,"_159":22,"_106":325,"_100":222,"_162":176,"_164":223,"_165":22,"_166":-5,"_98":326},["D",1747525929547],[99,218],{"_104":227,"_95":228,"_153":229,"_155":202,"_156":138,"_157":230,"_159":22,"_106":328,"_100":232,"_162":176,"_164":233,"_165":22,"_166":-5,"_98":329},["D",1747554347553],[99,228],{"_104":237,"_95":238,"_153":239,"_155":202,"_156":138,"_157":240,"_159":22,"_106":331,"_100":242,"_162":176,"_164":243,"_165":22,"_166":-5,"_98":332},["D",1747556152997],[99,238],{"_104":201,"_95":99,"_153":202,"_155":-5,"_156":138,"_157":203,"_159":22,"_106":334,"_100":32,"_162":163,"_164":-5,"_165":22,"_166":-5,"_98":335},["D",1747498274743],[99],"upstreamProject","upstreamBranch","emptyEnvVars","isNew","flags",[],"routes/_app.x.$handle.$name.branch.$branch.version.$version.code.$",{"_93":94,"_95":96,"_97":43,"_100":101,"_98":99,"_102":344,"_148":349,"_310":395,"_254":396,"_319":398,"_407":-5,"_408":22,"_409":-5,"_410":-5,"_411":-5,"_412":413},{"_104":105,"_95":96,"_106":345,"_108":-5,"_109":22,"_110":111,"_112":-5,"_113":-5,"_14":114,"_115":-5,"_116":22,"_117":-5,"_118":32,"_16":119,"_120":121,"_122":121,"_123":124,"_125":124,"_126":124,"_127":121,"_128":121,"_23":346,"_132":347,"_135":348,"_147":22},["D",1747457599190],{"_93":94,"_130":131},{"_93":94,"_134":131},{"_100":137,"_95":43,"_104":138,"_139":105,"_140":-5,"_141":-5,"_142":-5,"_143":-5,"_144":-5,"_145":96,"_146":94},[350,362,377,380,383,386,389,392],{"_104":151,"_95":152,"_153":154,"_155":-5,"_156":138,"_157":158,"_159":22,"_106":160,"_100":161,"_162":163,"_164":-5,"_165":22,"_166":-5,"_167":351,"_98":361},[352,355,358],{"_104":170,"_95":171,"_153":172,"_155":154,"_156":138,"_157":173,"_159":22,"_106":174,"_100":175,"_162":176,"_164":177,"_165":22,"_166":-5,"_167":353,"_98":354},[],[152,171],{"_104":181,"_95":182,"_153":183,"_155":154,"_156":138,"_157":184,"_159":22,"_106":185,"_100":186,"_162":176,"_164":187,"_165":22,"_166":-5,"_167":356,"_98":357},[],[152,182],{"_104":191,"_95":192,"_153":193,"_155":154,"_156":138,"_157":194,"_159":22,"_106":195,"_100":161,"_162":176,"_164":196,"_165":22,"_166":-5,"_167":359,"_98":360},[],[152,192],[152],{"_104":201,"_95":99,"_153":202,"_155":-5,"_156":138,"_157":203,"_159":22,"_106":204,"_100":32,"_162":163,"_164":-5,"_165":22,"_166":-5,"_167":363,"_98":376},[364,367,370,373],{"_104":207,"_95":208,"_153":209,"_155":202,"_156":138,"_157":210,"_159":22,"_106":211,"_100":212,"_162":176,"_164":213,"_165":22,"_166":-5,"_167":365,"_98":366},[],[99,208],{"_104":217,"_95":218,"_153":219,"_155":202,"_156":138,"_157":220,"_159":22,"_106":221,"_100":222,"_162":176,"_164":223,"_165":22,"_166":-5,"_167":368,"_98":369},[],[99,218],{"_104":227,"_95":228,"_153":229,"_155":202,"_156":138,"_157":230,"_159":22,"_106":231,"_100":232,"_162":176,"_164":233,"_165":22,"_166":-5,"_167":371,"_98":372},[],[99,228],{"_104":237,"_95":238,"_153":239,"_155":202,"_156":138,"_157":240,"_159":22,"_106":241,"_100":242,"_162":176,"_164":243,"_165":22,"_166":-5,"_167":374,"_98":375},[],[99,238],[99],{"_104":248,"_95":249,"_153":250,"_155":-5,"_156":138,"_157":251,"_159":252,"_106":253,"_100":161,"_162":254,"_164":255,"_165":22,"_166":-5,"_167":378,"_98":379},[],[249],{"_104":259,"_95":260,"_153":261,"_155":-5,"_156":138,"_157":101,"_159":22,"_106":262,"_100":263,"_162":264,"_164":265,"_165":22,"_166":266,"_167":381,"_98":382},[],[260],{"_104":270,"_95":271,"_153":272,"_155":-5,"_156":138,"_157":273,"_159":22,"_106":274,"_100":275,"_162":176,"_164":276,"_165":22,"_166":-5,"_167":384,"_98":385},[],[271],{"_104":280,"_95":281,"_153":282,"_155":-5,"_156":138,"_157":283,"_159":22,"_106":284,"_100":285,"_162":264,"_164":286,"_165":22,"_166":287,"_167":387,"_98":388},[],[281],{"_104":291,"_95":292,"_153":293,"_155":-5,"_156":138,"_157":294,"_159":22,"_106":295,"_100":296,"_162":176,"_164":297,"_165":22,"_166":-5,"_167":390,"_98":391},[],[292],{"_104":301,"_95":302,"_153":303,"_155":-5,"_156":138,"_157":304,"_159":22,"_106":305,"_100":306,"_162":176,"_164":307,"_165":22,"_166":-5,"_167":393,"_98":394},[],[302],[350,352,355,358,362,364,367,370,373,377,380,383,386,389,392],{"_104":201,"_95":99,"_153":202,"_155":-5,"_156":138,"_157":203,"_159":22,"_106":334,"_100":32,"_162":163,"_164":-5,"_165":22,"_166":-5,"_98":397},[99],[399,401,403,405],{"_104":207,"_95":208,"_153":209,"_155":202,"_156":138,"_157":210,"_159":22,"_106":322,"_100":212,"_162":176,"_164":213,"_165":22,"_166":-5,"_98":400},[99,208],{"_104":217,"_95":218,"_153":219,"_155":202,"_156":138,"_157":220,"_159":22,"_106":325,"_100":222,"_162":176,"_164":223,"_165":22,"_166":-5,"_98":402},[99,218],{"_104":227,"_95":228,"_153":229,"_155":202,"_156":138,"_157":230,"_159":22,"_106":328,"_100":232,"_162":176,"_164":233,"_165":22,"_166":-5,"_98":404},[99,228],{"_104":237,"_95":238,"_153":239,"_155":202,"_156":138,"_157":240,"_159":22,"_106":331,"_100":242,"_162":176,"_164":243,"_165":22,"_166":-5,"_98":406},[99,238],"upstream","showCompareCallout","pull","ahead","behind","templates",[],"actionData","errors"]