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],{"_103":270,"_95":271,"_152":272,"_154":-5,"_155":137,"_156":273,"_158":22,"_105":274,"_99":275,"_161":175,"_163":276,"_164":22,"_165":-5,"_166":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],{"_103":280,"_95":281,"_152":282,"_154":-5,"_155":137,"_156":283,"_158":22,"_105":284,"_99":285,"_161":264,"_163":286,"_164":22,"_165":287,"_166":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],{"_103":291,"_95":292,"_152":293,"_154":-5,"_155":137,"_156":294,"_158":22,"_105":295,"_99":296,"_161":175,"_163":297,"_164":22,"_165":-5,"_166":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],{"_103":301,"_95":302,"_152":303,"_154":-5,"_155":137,"_156":304,"_158":22,"_105":305,"_99":306,"_161":175,"_163":307,"_164":22,"_165":-5,"_166":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",[149,168,179,189,199,206,216,226,236,247,258,269,279,290,300],"counts",{"_314":32,"_315":160,"_316":32,"_317":318},"pulls","branches","forks","envVars",18,"contents",[321,324,327,330,333,336,339,342],{"_103":150,"_95":151,"_152":153,"_154":-5,"_155":137,"_156":157,"_158":22,"_105":322,"_99":160,"_161":162,"_163":-5,"_164":22,"_165":-5,"_98":323},["D",1747498047791],[151],{"_103":200,"_95":201,"_152":202,"_154":-5,"_155":137,"_156":203,"_158":22,"_105":325,"_99":32,"_161":162,"_163":-5,"_164":22,"_165":-5,"_98":326},["D",1747498274743],[201],{"_103":248,"_95":249,"_152":250,"_154":-5,"_155":137,"_156":251,"_158":252,"_105":328,"_99":160,"_161":254,"_163":255,"_164":22,"_165":-5,"_98":329},["D",1747498308627],[249],{"_103":259,"_95":260,"_152":261,"_154":-5,"_155":137,"_156":100,"_158":22,"_105":331,"_99":263,"_161":264,"_163":265,"_164":22,"_165":266,"_98":332},["D",1747661103392],[260],{"_103":270,"_95":271,"_152":272,"_154":-5,"_155":137,"_156":273,"_158":22,"_105":334,"_99":275,"_161":175,"_163":276,"_164":22,"_165":-5,"_98":335},["D",1747567681681],[271],{"_103":280,"_95":281,"_152":282,"_154":-5,"_155":137,"_156":283,"_158":22,"_105":337,"_99":285,"_161":264,"_163":286,"_164":22,"_165":287,"_98":338},["D",1747660893014],[281],{"_103":291,"_95":292,"_152":293,"_154":-5,"_155":137,"_156":294,"_158":22,"_105":340,"_99":296,"_161":175,"_163":297,"_164":22,"_165":-5,"_98":341},["D",1747552891317],[292],{"_103":301,"_95":302,"_152":303,"_154":-5,"_155":137,"_156":304,"_158":22,"_105":343,"_99":306,"_161":175,"_163":307,"_164":22,"_165":-5,"_98":344},["D",1747660046774],[302],"upstreamProject","upstreamBranch","emptyEnvVars","isNew","flags",[],"routes/_app.x.$handle.$name.branch.$branch.version.$version.code.$",{"_93":94,"_95":96,"_97":43,"_99":100,"_98":72,"_101":353,"_147":358,"_310":404,"_254":-7,"_319":405,"_422":-5,"_423":22,"_424":-5,"_425":-5,"_426":-5,"_427":428},{"_103":104,"_95":96,"_105":354,"_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":355,"_131":356,"_134":357,"_146":22},["D",1747457599190],{"_93":94,"_129":130},{"_93":94,"_133":130},{"_99":136,"_95":43,"_103":137,"_138":104,"_139":-5,"_140":-5,"_141":-5,"_142":-5,"_143":-5,"_144":96,"_145":94},[359,371,386,389,392,395,398,401],{"_103":150,"_95":151,"_152":153,"_154":-5,"_155":137,"_156":157,"_158":22,"_105":159,"_99":160,"_161":162,"_163":-5,"_164":22,"_165":-5,"_166":360,"_98":370},[361,364,367],{"_103":169,"_95":170,"_152":171,"_154":153,"_155":137,"_156":172,"_158":22,"_105":173,"_99":174,"_161":175,"_163":176,"_164":22,"_165":-5,"_166":362,"_98":363},[],[151,170],{"_103":180,"_95":181,"_152":182,"_154":153,"_155":137,"_156":183,"_158":22,"_105":184,"_99":185,"_161":175,"_163":186,"_164":22,"_165":-5,"_166":365,"_98":366},[],[151,181],{"_103":190,"_95":191,"_152":192,"_154":153,"_155":137,"_156":193,"_158":22,"_105":194,"_99":160,"_161":175,"_163":195,"_164":22,"_165":-5,"_166":368,"_98":369},[],[151,191],[151],{"_103":200,"_95":201,"_152":202,"_154":-5,"_155":137,"_156":203,"_158":22,"_105":204,"_99":32,"_161":162,"_163":-5,"_164":22,"_165":-5,"_166":372,"_98":385},[373,376,379,382],{"_103":207,"_95":208,"_152":209,"_154":202,"_155":137,"_156":210,"_158":22,"_105":211,"_99":212,"_161":175,"_163":213,"_164":22,"_165":-5,"_166":374,"_98":375},[],[201,208],{"_103":217,"_95":218,"_152":219,"_154":202,"_155":137,"_156":220,"_158":22,"_105":221,"_99":222,"_161":175,"_163":223,"_164":22,"_165":-5,"_166":377,"_98":378},[],[201,218],{"_103":227,"_95":228,"_152":229,"_154":202,"_155":137,"_156":230,"_158":22,"_105":231,"_99":232,"_161":175,"_163":233,"_164":22,"_165":-5,"_166":380,"_98":381},[],[201,228],{"_103":237,"_95":238,"_152":239,"_154":202,"_155":137,"_156":240,"_158":22,"_105":241,"_99":242,"_161":175,"_163":243,"_164":22,"_165":-5,"_166":383,"_98":384},[],[201,238],[201],{"_103":248,"_95":249,"_152":250,"_154":-5,"_155":137,"_156":251,"_158":252,"_105":253,"_99":160,"_161":254,"_163":255,"_164":22,"_165":-5,"_166":387,"_98":388},[],[249],{"_103":259,"_95":260,"_152":261,"_154":-5,"_155":137,"_156":100,"_158":22,"_105":262,"_99":263,"_161":264,"_163":265,"_164":22,"_165":266,"_166":390,"_98":391},[],[260],{"_103":270,"_95":271,"_152":272,"_154":-5,"_155":137,"_156":273,"_158":22,"_105":274,"_99":275,"_161":175,"_163":276,"_164":22,"_165":-5,"_166":393,"_98":394},[],[271],{"_103":280,"_95":281,"_152":282,"_154":-5,"_155":137,"_156":283,"_158":22,"_105":284,"_99":285,"_161":264,"_163":286,"_164":22,"_165":287,"_166":396,"_98":397},[],[281],{"_103":291,"_95":292,"_152":293,"_154":-5,"_155":137,"_156":294,"_158":22,"_105":295,"_99":296,"_161":175,"_163":297,"_164":22,"_165":-5,"_166":399,"_98":400},[],[292],{"_103":301,"_95":302,"_152":303,"_154":-5,"_155":137,"_156":304,"_158":22,"_105":305,"_99":306,"_161":175,"_163":307,"_164":22,"_165":-5,"_166":402,"_98":403},[],[302],[359,361,364,367,371,373,376,379,382,386,389,392,395,398,401],[406,408,410,412,414,416,418,420],{"_103":150,"_95":151,"_152":153,"_154":-5,"_155":137,"_156":157,"_158":22,"_105":322,"_99":160,"_161":162,"_163":-5,"_164":22,"_165":-5,"_98":407},[151],{"_103":200,"_95":201,"_152":202,"_154":-5,"_155":137,"_156":203,"_158":22,"_105":325,"_99":32,"_161":162,"_163":-5,"_164":22,"_165":-5,"_98":409},[201],{"_103":248,"_95":249,"_152":250,"_154":-5,"_155":137,"_156":251,"_158":252,"_105":328,"_99":160,"_161":254,"_163":255,"_164":22,"_165":-5,"_98":411},[249],{"_103":259,"_95":260,"_152":261,"_154":-5,"_155":137,"_156":100,"_158":22,"_105":331,"_99":263,"_161":264,"_163":265,"_164":22,"_165":266,"_98":413},[260],{"_103":270,"_95":271,"_152":272,"_154":-5,"_155":137,"_156":273,"_158":22,"_105":334,"_99":275,"_161":175,"_163":276,"_164":22,"_165":-5,"_98":415},[271],{"_103":280,"_95":281,"_152":282,"_154":-5,"_155":137,"_156":283,"_158":22,"_105":337,"_99":285,"_161":264,"_163":286,"_164":22,"_165":287,"_98":417},[281],{"_103":291,"_95":292,"_152":293,"_154":-5,"_155":137,"_156":294,"_158":22,"_105":340,"_99":296,"_161":175,"_163":297,"_164":22,"_165":-5,"_98":419},[292],{"_103":301,"_95":302,"_152":303,"_154":-5,"_155":137,"_156":304,"_158":22,"_105":343,"_99":306,"_161":175,"_163":307,"_164":22,"_165":-5,"_98":421},[302],"upstream","showCompareCallout","pull","ahead","behind","templates",[],"actionData","errors"]