[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_245":246,"_247":248},"routes/_app.x.$handle.$name",{"_98":97,"_32":46,"_106":88,"_27":107,"_13":14,"_108":-5,"_11":109,"_110":111,"_112":113,"_114":115,"_116":117,"_20":-5,"_118":-5,"_119":-5,"_120":25,"_121":122,"_123":60,"_124":-5,"_125":-5,"_126":127},"routes/_app.x.$handle.$name.branch.$branch.version.$version.diff",{"_11":12,"_13":14,"_15":16,"_17":-5,"_18":-5},"project",{"_44":45,"_32":46,"_39":47,"_48":-5,"_49":25,"_50":51,"_52":51,"_53":54,"_55":-5,"_18":56,"_57":58,"_59":60,"_61":60,"_62":-5,"_63":64,"_65":66,"_67":-5,"_68":-5,"_69":-5,"_70":-5,"_71":72,"_73":72,"_74":75,"_76":75,"_77":75,"_78":72,"_79":72,"_80":81,"_82":83,"_84":85,"_86":25},"version",10,"changes",[19],"aiChatInfo","userId",{"_20":21,"_22":23,"_24":25,"_26":25,"_27":28,"_29":28},"file",{"_30":31,"_32":33,"_34":35,"_36":38,"_39":40,"_41":14,"_42":43,"_24":25},"previous",{"_30":31,"_32":33,"_34":35,"_36":37},"deleted",false,"deletedHere","path","backend/mcp/resources.ts","latestPath","fileId","f6e5ab04-3c09-11f0-92ed-9e149126039e","name","resources.ts","fileType","script","content","/**\n * MCP Resources - Val Town resources exposed through MCP\n */\n\nimport { blob } from \"https://esm.town/v/std/blob\";\nimport { sqlite } from \"https://esm.town/v/stevekrouse/sqlite\";\nimport { readFile, listFiles } from \"https://esm.town/v/std/utils@85-main/index.ts\";\nimport { MCPResource } from \"./types.ts\";\nimport { MCPException, MCP_ERRORS } from \"../../shared/utils.ts\";\n\nexport async function listResources(): Promise {\n const resources: MCPResource[] = [];\n \n try {\n // Add blob storage resources\n const blobKeys = await blob.list(\"\");\n for (const key of blobKeys) {\n resources.push({\n uri: `blob://${key}`,\n name: `Blob: ${key}`,\n description: `Val Town blob storage item: ${key}`,\n mimeType: \"application/json\"\n });\n }\n } catch (error) {\n // Continue if blob listing fails\n }\n \n try {\n // Add project files as resources\n const files = await listFiles(import.meta.url);\n for (const file of files) {\n const mimeType = getMimeType(file);\n resources.push({\n uri: `file://${file}`,\n name: `File: ${file}`,\n description: `Project file: ${file}`,\n mimeType\n });\n }\n } catch (error) {\n // Continue if file listing fails\n }\n \n // Add database schema as a resource\n resources.push({\n uri: \"sqlite://schema\",\n name: \"SQLite Schema\",\n description: \"Database schema information\",\n mimeType: \"application/json\"\n });\n \n // Add environment info as a resource\n resources.push({\n uri: \"env://info\",\n name: \"Environment Info\",\n description: \"Available environment variables (names only)\",\n mimeType: \"application/json\"\n });\n \n return resources;\n}\n\nexport async function readResource(uri: string): Promise<{ contents: Array<{ uri: string; mimeType?: string; text?: string }> }> {\n const [scheme, path] = uri.split(\"://\", 2);\n \n switch (scheme) {\n case \"blob\":\n return await readBlobResource(path);\n case \"file\":\n return await readFileResource(path);\n case \"sqlite\":\n return await readSqliteResource(path);\n case \"env\":\n return await readEnvResource(path);\n default:\n throw new MCPException(MCP_ERRORS.RESOURCE_NOT_FOUND, `Unknown resource scheme: ${scheme}`);\n }\n}\n\nasync function readBlobResource(key: string): Promise<{ contents: Array<{ uri: string; mimeType?: string; text?: string }> }> {\n try {\n const value = await blob.getJSON(key);\n return {\n contents: [{\n uri: `blob://${key}`,\n mimeType: \"application/json\",\n text: JSON.stringify(value, null, 2)\n }]\n };\n } catch (error) {\n // Try as text if JSON fails\n try {\n const value = await blob.get(key);\n return {\n contents: [{\n uri: `blob://${key}`,\n mimeType: \"text/plain\",\n text: value\n }]\n };\n } catch (textError) {\n throw new MCPException(MCP_ERRORS.RESOURCE_NOT_FOUND, `Blob not found: ${key}`);\n }\n }\n}\n\nasync function readFileResource(path: string): Promise<{ contents: Array<{ uri: string; mimeType?: string; text?: string }> }> {\n try {\n const content = await readFile(path, import.meta.url);\n return {\n contents: [{\n uri: `file://${path}`,\n mimeType: getMimeType(path),\n text: content\n }]\n };\n } catch (error) {\n throw new MCPException(MCP_ERRORS.RESOURCE_NOT_FOUND, `File not found: ${path}`);\n }\n}\n\nasync function readSqliteResource(resource: string): Promise<{ contents: Array<{ uri: string; mimeType?: string; text?: string }> }> {\n if (resource === \"schema\") {\n try {\n // Get table information\n const tables = await sqlite.execute(\"SELECT name FROM sqlite_master WHERE type='table'\");\n const schema: any = { tables: [] };\n \n for (const table of tables) {\n const tableInfo = await sqlite.execute(`PRAGMA table_info(${table.name})`);\n schema.tables.push({\n name: table.name,\n columns: tableInfo\n });\n }\n \n return {\n contents: [{\n uri: \"sqlite://schema\",\n mimeType: \"application/json\",\n text: JSON.stringify(schema, null, 2)\n }]\n };\n } catch (error) {\n throw new MCPException(MCP_ERRORS.INTERNAL_ERROR, `Error reading database schema: ${error.message}`);\n }\n }\n \n throw new MCPException(MCP_ERRORS.RESOURCE_NOT_FOUND, `Unknown SQLite resource: ${resource}`);\n}\n\nasync function readEnvResource(resource: string): Promise<{ contents: Array<{ uri: string; mimeType?: string; text?: string }> }> {\n if (resource === \"info\") {\n // Only return environment variable names for security\n const envVars = Object.keys(Deno.env.toObject()).map(key => ({\n name: key,\n exists: true,\n value: \"[REDACTED]\" // Don't expose actual values\n }));\n \n return {\n contents: [{\n uri: \"env://info\",\n mimeType: \"application/json\",\n text: JSON.stringify({ environmentVariables: envVars }, null, 2)\n }]\n };\n }\n \n throw new MCPException(MCP_ERRORS.RESOURCE_NOT_FOUND, `Unknown environment resource: ${resource}`);\n}\n\nfunction getMimeType(filename: string): string {\n const ext = filename.split('.').pop()?.toLowerCase();\n \n const mimeTypes: Record = {\n 'html': 'text/html',\n 'css': 'text/css',\n 'js': 'application/javascript',\n 'ts': 'application/typescript',\n 'tsx': 'application/typescript',\n 'json': 'application/json',\n 'md': 'text/markdown',\n 'txt': 'text/plain',\n 'svg': 'image/svg+xml',\n 'png': 'image/png',\n 'jpg': 'image/jpeg',\n 'jpeg': 'image/jpeg',\n 'gif': 'image/gif'\n };\n \n return mimeTypes[ext || ''] || 'text/plain';\n}","/**\n * MCP Resources - Val Town resources exposed through MCP\n */\n\nimport { blob } from \"https://esm.town/v/std/blob\";\nimport { sqlite } from \"https://esm.town/v/stevekrouse/sqlite\";\nimport { readFile, listFiles } from \"https://esm.town/v/std/utils@85-main/index.ts\";\nimport { MCPResource } from \"./types.ts\";\nimport { MCPException, MCP_ERRORS } from \"../../shared/utils.ts\";\n\nexport async function listResources(): Promise {\n const resources: MCPResource[] = [];\n \n try {\n // Add blob storage resources\n const blobKeys = await blob.list(\"\");\n for (const key of blobKeys) {\n // Handle case where key might be an object\n const keyStr = typeof key === 'string' ? key : JSON.stringify(key);\n resources.push({\n uri: `blob://${keyStr}`,\n name: `Blob: ${keyStr}`,\n description: `Val Town blob storage item: ${keyStr}`,\n mimeType: \"application/json\"\n });\n }\n } catch (error) {\n // Continue if blob listing fails\n }\n \n try {\n // Add project files as resources\n const files = await listFiles(import.meta.url);\n for (const file of files) {\n const mimeType = getMimeType(file);\n resources.push({\n uri: `file://${file}`,\n name: `File: ${file}`,\n description: `Project file: ${file}`,\n mimeType\n });\n }\n } catch (error) {\n // Continue if file listing fails\n }\n \n // Add database schema as a resource\n resources.push({\n uri: \"sqlite://schema\",\n name: \"SQLite Schema\",\n description: \"Database schema information\",\n mimeType: \"application/json\"\n });\n \n // Add environment info as a resource\n resources.push({\n uri: \"env://info\",\n name: \"Environment Info\",\n description: \"Available environment variables (names only)\",\n mimeType: \"application/json\"\n });\n \n return resources;\n}\n\nexport async function readResource(uri: string): Promise<{ contents: Array<{ uri: string; mimeType?: string; text?: string }> }> {\n const [scheme, path] = uri.split(\"://\", 2);\n \n switch (scheme) {\n case \"blob\":\n return await readBlobResource(path);\n case \"file\":\n return await readFileResource(path);\n case \"sqlite\":\n return await readSqliteResource(path);\n case \"env\":\n return await readEnvResource(path);\n default:\n throw new MCPException(MCP_ERRORS.RESOURCE_NOT_FOUND, `Unknown resource scheme: ${scheme}`);\n }\n}\n\nasync function readBlobResource(key: string): Promise<{ contents: Array<{ uri: string; mimeType?: string; text?: string }> }> {\n try {\n const value = await blob.getJSON(key);\n return {\n contents: [{\n uri: `blob://${key}`,\n mimeType: \"application/json\",\n text: JSON.stringify(value, null, 2)\n }]\n };\n } catch (error) {\n // Try as text if JSON fails\n try {\n const value = await blob.get(key);\n return {\n contents: [{\n uri: `blob://${key}`,\n mimeType: \"text/plain\",\n text: value\n }]\n };\n } catch (textError) {\n throw new MCPException(MCP_ERRORS.RESOURCE_NOT_FOUND, `Blob not found: ${key}`);\n }\n }\n}\n\nasync function readFileResource(path: string): Promise<{ contents: Array<{ uri: string; mimeType?: string; text?: string }> }> {\n try {\n const content = await readFile(path, import.meta.url);\n return {\n contents: [{\n uri: `file://${path}`,\n mimeType: getMimeType(path),\n text: content\n }]\n };\n } catch (error) {\n throw new MCPException(MCP_ERRORS.RESOURCE_NOT_FOUND, `File not found: ${path}`);\n }\n}\n\nasync function readSqliteResource(resource: string): Promise<{ contents: Array<{ uri: string; mimeType?: string; text?: string }> }> {\n if (resource === \"schema\") {\n try {\n // Get table information\n const tables = await sqlite.execute(\"SELECT name FROM sqlite_master WHERE type='table'\");\n const schema: any = { tables: [] };\n \n for (const table of tables) {\n const tableInfo = await sqlite.execute(`PRAGMA table_info(${table.name})`);\n schema.tables.push({\n name: table.name,\n columns: tableInfo\n });\n }\n \n return {\n contents: [{\n uri: \"sqlite://schema\",\n mimeType: \"application/json\",\n text: JSON.stringify(schema, null, 2)\n }]\n };\n } catch (error) {\n throw new MCPException(MCP_ERRORS.INTERNAL_ERROR, `Error reading database schema: ${error.message}`);\n }\n }\n \n throw new MCPException(MCP_ERRORS.RESOURCE_NOT_FOUND, `Unknown SQLite resource: ${resource}`);\n}\n\nasync function readEnvResource(resource: string): Promise<{ contents: Array<{ uri: string; mimeType?: string; text?: string }> }> {\n if (resource === \"info\") {\n // Only return environment variable names for security\n const envVars = Object.keys(Deno.env.toObject()).map(key => ({\n name: key,\n exists: true,\n value: \"[REDACTED]\" // Don't expose actual values\n }));\n \n return {\n contents: [{\n uri: \"env://info\",\n mimeType: \"application/json\",\n text: JSON.stringify({ environmentVariables: envVars }, null, 2)\n }]\n };\n }\n \n throw new MCPException(MCP_ERRORS.RESOURCE_NOT_FOUND, `Unknown environment resource: ${resource}`);\n}\n\nfunction getMimeType(filename: string): string {\n const ext = filename.split('.').pop()?.toLowerCase();\n \n const mimeTypes: Record = {\n 'html': 'text/html',\n 'css': 'text/css',\n 'js': 'application/javascript',\n 'ts': 'application/typescript',\n 'tsx': 'application/typescript',\n 'json': 'application/json',\n 'md': 'text/markdown',\n 'txt': 'text/plain',\n 'svg': 'image/svg+xml',\n 'png': 'image/png',\n 'jpg': 'image/jpeg',\n 'jpeg': 'image/jpeg',\n 'gif': 'image/gif'\n };\n \n return mimeTypes[ext || ''] || 'text/plain';\n}","createdAt",["D",1748467679130],"branchVersion","branchId","e1ff5798-3b9c-11f0-96f0-9e149126039e","id","e1ff20a2-3b9c-11f0-96f0-9e149126039e","MCP",["D",1748420544100],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","Lightweight MCP server lib for Val.town","imageUrl","21f2e37e-8066-4730-9dc7-d27cf8d3c9f3","pinnedFileId","81c497c6-3c0a-11f0-81e2-9e149126039e","pinPreview",true,"pinMigrated","screenshotVersion","likeCount",0,"orgId","0630d977-f678-453e-926c-52043293f59f","tursoName","tursoHostname","tursoMeasuredAt","pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_98":97,"_105":101},"org",{"_98":97,"_99":-5,"_100":101,"_18":56,"_102":103,"_104":25},"branch",{"_13":87,"_32":88,"_44":43,"_89":45,"_90":-5,"_91":-5,"_92":-5,"_93":-5,"_94":-5,"_95":46,"_96":97},"isOwned",39,"main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","c15r","handle","displayName","avatar","https://img.clerk.com/eyJ0eXBlIjoicHJveHkiLCJzcmMiOiJodHRwczovL2ltYWdlcy5jbGVyay5kZXYvb2F1dGhfZ2l0aHViL2ltZ18yb2RJNlc1czZ1NlpZRmoxdGJ2eFVNNVhmeTYifQ","tier","pro","canRestrictVals","profileImageUrl","branchName","","adoptOrgId",{"_44":45,"_32":46,"_39":241,"_48":-5,"_49":25,"_50":51,"_52":51,"_53":54,"_55":-5,"_18":56,"_57":58,"_59":60,"_61":60,"_62":-5,"_63":64,"_65":66,"_67":-5,"_68":-5,"_69":-5,"_70":-5,"_71":72,"_73":72,"_74":75,"_76":75,"_77":75,"_78":72,"_79":72,"_80":242,"_82":243,"_84":244,"_86":25},"tree",[164,172,174],"files",[164,165,166,167,168,169,170,171,172,173,174],"counts",{"_154":64,"_155":135,"_156":64,"_157":158,"_159":160},"contents",[128,129,130],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},{"_44":148,"_32":149,"_30":150,"_134":-5,"_42":43,"_41":151,"_136":60,"_39":152,"_13":64,"_34":146,"_36":-5,"_24":25,"_139":-5,"_27":153},{"_44":141,"_32":142,"_30":143,"_134":-5,"_42":43,"_41":144,"_136":60,"_39":145,"_13":64,"_34":146,"_36":-5,"_24":25,"_139":-5,"_27":147},{"_44":131,"_32":132,"_30":133,"_134":-5,"_42":43,"_41":135,"_136":25,"_39":137,"_13":64,"_34":20,"_36":138,"_24":25,"_139":-5,"_27":140},"c9000c16-3c09-11f0-a57a-9e149126039e","README.md","c9000cca-3c09-11f0-a57a-9e149126039e","parentId",1,"latest",["D",1748467317303],"# Val Town MCP Server\n\nA Model Context Protocol (MCP) server that exposes Val Town's native tools and resources, allowing AI models to interact with Val Town's capabilities through a standardized protocol.\n\n## Features\n\n- **Blob Storage**: Read, write, list, and delete blob data\n- **SQLite Database**: Execute queries and manage database operations\n- **Email**: Send emails through Val Town's email service\n- **OpenAI Integration**: Access OpenAI API through Val Town's service\n- **File Operations**: Read and list project files\n- **Environment Variables**: Access environment configuration\n\n## MCP Protocol Support\n\nThis server implements the Model Context Protocol specification, providing:\n- Tool discovery and execution\n- Resource listing and reading\n- Proper error handling and validation\n- JSON-RPC 2.0 compliant messaging\n\n## API Endpoints\n\n- `POST /mcp` - Main MCP protocol endpoint\n- `GET /` - Server information and documentation\n\n## Usage\n\nThe server exposes Val Town capabilities as MCP tools that can be called by compatible AI models and clients.\n\n## Project Structure\n\n```\n├── backend/\n│ ├── index.ts # Main HTTP server\n│ ├── mcp/\n│ │ ├── server.ts # MCP protocol handler\n│ │ ├── tools.ts # Tool definitions and handlers\n│ │ ├── resources.ts # Resource definitions and handlers\n│ │ └── types.ts # MCP type definitions\n│ └── README.md\n├── shared/\n│ └── utils.ts # Shared utilities\n└── README.md\n```","label",[132],"cd9d2b82-3c09-11f0-8c8b-9e149126039e","shared","a0461c89-f398-426b-afac-535542e9505b",2,["D",1748467325043],"directory",[142],"d20c4bc6-3c09-11f0-b62a-9e149126039e","backend","52a0890e-2351-4d07-b870-7d21fa9d4b87",3,["D",1748467332476],[149],"pulls","branches","forks","envVars",{"_161":64,"_163":64},"connections",{"_161":64,"_162":64},"count","unfilledCount","emptyCount",{"_44":148,"_32":149,"_30":150,"_134":-5,"_42":43,"_41":151,"_136":60,"_39":238,"_13":64,"_34":146,"_36":-5,"_24":25,"_139":-5,"_176":239,"_27":240},{"_44":234,"_32":213,"_30":208,"_134":150,"_42":43,"_41":151,"_136":60,"_39":235,"_13":64,"_34":146,"_36":-5,"_24":25,"_139":-5,"_176":236,"_27":237},{"_44":230,"_32":33,"_30":31,"_134":208,"_42":43,"_41":14,"_136":60,"_39":231,"_13":135,"_34":35,"_36":38,"_24":25,"_139":-5,"_176":232,"_27":233},{"_44":222,"_32":223,"_30":224,"_134":208,"_42":43,"_41":225,"_136":60,"_39":226,"_13":64,"_34":35,"_36":227,"_24":25,"_139":-5,"_176":228,"_27":229},{"_44":214,"_32":215,"_30":216,"_134":208,"_42":43,"_41":217,"_136":60,"_39":218,"_13":64,"_34":35,"_36":219,"_24":25,"_139":-5,"_176":220,"_27":221},{"_44":205,"_32":206,"_30":207,"_134":208,"_42":43,"_41":151,"_136":60,"_39":209,"_13":64,"_34":35,"_36":210,"_24":25,"_139":-5,"_176":211,"_27":212},{"_44":198,"_32":132,"_30":199,"_134":150,"_42":43,"_41":200,"_136":60,"_39":201,"_13":64,"_34":20,"_36":202,"_24":25,"_139":-5,"_176":203,"_27":204},{"_44":189,"_32":190,"_30":58,"_134":150,"_42":43,"_41":191,"_136":25,"_39":192,"_13":135,"_34":193,"_36":194,"_24":25,"_139":195,"_176":196,"_27":197},{"_44":141,"_32":142,"_30":143,"_134":-5,"_42":43,"_41":144,"_136":60,"_39":186,"_13":64,"_34":146,"_36":-5,"_24":25,"_139":-5,"_176":187,"_27":188},{"_44":179,"_32":180,"_30":181,"_134":143,"_42":43,"_41":144,"_136":60,"_39":182,"_13":64,"_34":35,"_36":183,"_24":25,"_139":-5,"_176":184,"_27":185},{"_44":131,"_32":132,"_30":133,"_134":-5,"_42":43,"_41":135,"_136":25,"_39":175,"_13":64,"_34":20,"_36":138,"_24":25,"_139":-5,"_176":177,"_27":178},["D",1748467317303],"children",[],[132],"cd9d0fc6-3c09-11f0-8c8b-9e149126039e","utils.ts","cd9d1098-3c09-11f0-8c8b-9e149126039e",["D",1748467325043],"/**\n * Shared utilities for the MCP server\n */\n\nexport interface MCPError {\n code: number;\n message: string;\n data?: any;\n}\n\nexport class MCPException extends Error {\n code: number;\n data?: any;\n\n constructor(code: number, message: string, data?: any) {\n super(message);\n this.code = code;\n this.data = data;\n this.name = 'MCPException';\n }\n}\n\n// MCP Error Codes\nexport const MCP_ERRORS = {\n PARSE_ERROR: -32700,\n INVALID_REQUEST: -32600,\n METHOD_NOT_FOUND: -32601,\n INVALID_PARAMS: -32602,\n INTERNAL_ERROR: -32603,\n TOOL_NOT_FOUND: -32000,\n RESOURCE_NOT_FOUND: -32001,\n PERMISSION_DENIED: -32002,\n} as const;\n\nexport function validateRequired(params: any, required: string[]): void {\n for (const field of required) {\n if (params[field] === undefined || params[field] === null) {\n throw new MCPException(\n MCP_ERRORS.INVALID_PARAMS,\n `Missing required parameter: ${field}`\n );\n }\n }\n}\n\nexport function sanitizeKey(key: string): string {\n // Ensure blob keys are safe\n return key.replace(/[^a-zA-Z0-9_\\-\\.\\/]/g, '_');\n}",[],[142,180],["D",1748467325043],[173],[142],"851a1798-3c0a-11f0-8265-9e149126039e","index.ts",9,["D",1748467632883],"http","/**\n * Val Town MCP Server - Main HTTP Entry Point\n */\n\nimport { Hono } from \"https://esm.sh/hono@3.11.7\";\nimport { handleMCPRequest, getServerInfo } from \"./mcp/server.ts\";\nimport { MCPRequest } from \"./mcp/types.ts\";\n\nconst app = new Hono();\n\n// Unwrap Hono errors to see original error details\napp.onError((err, c) => {\n throw err;\n});\n\n// Main MCP endpoint\napp.post(\"/mcp\", async (c) => {\n try {\n const request: MCPRequest = await c.req.json();\n const response = await handleMCPRequest(request);\n \n return c.json(response);\n } catch (error) {\n return c.json({\n jsonrpc: \"2.0\",\n error: {\n code: -32700,\n message: \"Parse error\",\n data: error.message\n }\n }, 400);\n }\n});\n\n// Server information endpoint\napp.get(\"/\", (c) => {\n const serverInfo = getServerInfo();\n \n const html = `\n\n\n\n \n \n Val Town MCP Server\n \n\n\n

🏔️ Val Town MCP Server

Model Context Protocol server exposing Val Town's native tools and resources

\n\n

📋 Server Info

Name:: ${serverInfo.name}
Version:: ${serverInfo.version}
Protocol Version:: ${serverInfo.protocolVersion}

\n\n

🔧 Capabilities

\n \n Tools (10 available)\n
\n \n Resources (Dynamic discovery)\n
\n \n Logging\n

\n\n

🛠️ Available Tools

💾 Blob Storage

• blob_get
• blob_set
• blob_list
• blob_delete

🗄️ SQLite Database

• sqlite_execute

📧 Email

• email_send

🤖 OpenAI

• openai_chat

📁 File Operations

• file_read
• file_list

🌍 Environment

• env_get

\n\n

🔗 Usage

MCP Endpoint

\n POST /mcp\n

Send JSON-RPC 2.0 requests to interact with the MCP server

\n \n

Example Request

{\n  \"jsonrpc\": \"2.0\",\n  \"id\": 1,\n  \"method\": \"tools/list\"\n}

\n\n

Health Check

{\n  \"jsonrpc\": \"2.0\",\n  \"id\": 1,\n  \"method\": \"ping\"\n}

\n\n \n

\n\n`;\n\n return c.html(html);\n});\n\n// Health check endpoint\napp.get(\"/health\", (c) => {\n return c.json({ \n status: \"healthy\", \n timestamp: new Date().toISOString(),\n server: getServerInfo().name\n });\n});\n\n// API documentation endpoint\napp.get(\"/api/docs\", async (c) => {\n const { TOOLS } = await import(\"./mcp/tools.ts\");\n \n return c.json({\n server: getServerInfo(),\n tools: TOOLS,\n endpoints: {\n mcp: \"POST /mcp - Main MCP protocol endpoint\",\n health: \"GET /health - Health check\",\n docs: \"GET /api/docs - This documentation\"\n },\n examples: {\n initialize: {\n jsonrpc: \"2.0\",\n id: 1,\n method: \"initialize\",\n params: {}\n },\n listTools: {\n jsonrpc: \"2.0\",\n id: 2,\n method: \"tools/list\"\n },\n callTool: {\n jsonrpc: \"2.0\",\n id: 3,\n method: \"tools/call\",\n params: {\n name: \"blob_get\",\n arguments: { key: \"example-key\" }\n }\n }\n }\n });\n});\n\n// This is the entry point for HTTP vals\nexport default app.fetch;","val-mcp",[],[149,190],"05b2c752-3c0a-11f0-a67a-9e149126039e","05b2c7f2-3c0a-11f0-a67a-9e149126039e",7,["D",1748467419138],"# Backend - MCP Server\n\nThis directory contains the MCP (Model Context Protocol) server implementation that exposes Val Town's native capabilities.\n\n## Structure\n\n- `index.ts` - Main HTTP server entry point\n- `mcp/` - MCP protocol implementation\n - `server.ts` - Core MCP request/response handling\n - `tools.ts` - Tool definitions and execution handlers\n - `resources.ts` - Resource discovery and reading\n - `types.ts` - TypeScript type definitions for MCP protocol\n\n## MCP Protocol Methods\n\n### Core Methods\n- `initialize` - Initialize the MCP session\n- `ping` - Health check\n\n### Tools\n- `tools/list` - List available tools\n- `tools/call` - Execute a tool\n\n### Resources\n- `resources/list` - List available resources\n- `resources/read` - Read a resource\n\n## Available Tools\n\n1. **Blob Storage**\n - `blob_get` - Retrieve blob data\n - `blob_set` - Store blob data\n - `blob_list` - List blob keys\n - `blob_delete` - Delete blob\n\n2. **SQLite Database**\n - `sqlite_execute` - Execute SQL queries\n\n3. **Email**\n - `email_send` - Send emails\n\n4. **OpenAI**\n - `openai_chat` - Generate text with OpenAI\n\n5. **File Operations**\n - `file_read` - Read project files\n - `file_list` - List project files\n\n6. **Environment**\n - `env_get` - Get environment variables (names only for security)\n\n## Available Resources\n\n- `blob://[key]` - Blob storage items\n- `file://[path]` - Project files\n- `sqlite://schema` - Database schema\n- `env://info` - Environment variable info",[],[149,132],"d20c1ac0-3c09-11f0-b62a-9e149126039e","types.ts","d20c1be2-3c09-11f0-b62a-9e149126039e","1fef3adc-7b8f-4194-b683-4677cd81a45e",["D",1748467332476],"/**\n * MCP Protocol Type Definitions\n */\n\nexport interface MCPRequest {\n jsonrpc: \"2.0\";\n id?: string | number;\n method: string;\n params?: any;\n}\n\nexport interface MCPResponse {\n jsonrpc: \"2.0\";\n id?: string | number;\n result?: any;\n error?: MCPError;\n}\n\nexport interface MCPError {\n code: number;\n message: string;\n data?: any;\n}\n\nexport interface MCPTool {\n name: string;\n description: string;\n inputSchema: {\n type: \"object\";\n properties: Record;\n required?: string[];\n };\n}\n\nexport interface MCPResource {\n uri: string;\n name: string;\n description?: string;\n mimeType?: string;\n}\n\nexport interface MCPToolCall {\n name: string;\n arguments: Record;\n}\n\nexport interface MCPToolResult {\n content: Array<{\n type: \"text\" | \"image\" | \"resource\";\n text?: string;\n data?: string;\n mimeType?: string;\n }>;\n isError?: boolean;\n}\n\n// Server Info\nexport interface MCPServerInfo {\n name: string;\n version: string;\n protocolVersion: string;\n capabilities: {\n tools?: {};\n resources?: {};\n prompts?: {};\n logging?: {};\n };\n}",[],[149,213,206],"mcp","e81d8ae2-3c09-11f0-a538-9e149126039e","tools.ts","e81d8b96-3c09-11f0-a538-9e149126039e",4,["D",1748467369504],"/**\n * MCP Tools - Val Town capabilities exposed as MCP tools\n */\n\nimport { blob } from \"https://esm.town/v/std/blob\";\nimport { sqlite } from \"https://esm.town/v/stevekrouse/sqlite\";\nimport { email } from \"https://esm.town/v/std/email\";\nimport { OpenAI } from \"https://esm.town/v/std/openai\";\nimport { readFile, listFiles } from \"https://esm.town/v/std/utils@85-main/index.ts\";\nimport { MCPTool, MCPToolResult } from \"./types.ts\";\nimport { validateRequired, sanitizeKey, MCPException, MCP_ERRORS } from \"../../shared/utils.ts\";\n\nexport const TOOLS: MCPTool[] = [\n {\n name: \"blob_get\",\n description: \"Get data from Val Town blob storage\",\n inputSchema: {\n type: \"object\",\n properties: {\n key: { type: \"string\", description: \"The blob key to retrieve\" },\n type: { type: \"string\", enum: [\"json\", \"text\"], default: \"json\", description: \"Data type to retrieve\" }\n },\n required: [\"key\"]\n }\n },\n {\n name: \"blob_set\",\n description: \"Store data in Val Town blob storage\",\n inputSchema: {\n type: \"object\",\n properties: {\n key: { type: \"string\", description: \"The blob key to store data under\" },\n value: { description: \"The data to store\" },\n type: { type: \"string\", enum: [\"json\", \"text\"], default: \"json\", description: \"Data type to store\" }\n },\n required: [\"key\", \"value\"]\n }\n },\n {\n name: \"blob_list\",\n description: \"List blob keys with optional prefix filter\",\n inputSchema: {\n type: \"object\",\n properties: {\n prefix: { type: \"string\", description: \"Optional prefix to filter keys\" }\n }\n }\n },\n {\n name: \"blob_delete\",\n description: \"Delete a blob from storage\",\n inputSchema: {\n type: \"object\",\n properties: {\n key: { type: \"string\", description: \"The blob key to delete\" }\n },\n required: [\"key\"]\n }\n },\n {\n name: \"sqlite_execute\",\n description: \"Execute a SQLite query\",\n inputSchema: {\n type: \"object\",\n properties: {\n query: { type: \"string\", description: \"SQL query to execute\" },\n params: { type: \"array\", description: \"Query parameters\", items: {} }\n },\n required: [\"query\"]\n }\n },\n {\n name: \"email_send\",\n description: \"Send an email through Val Town\",\n inputSchema: {\n type: \"object\",\n properties: {\n to: { type: \"string\", description: \"Recipient email address (optional, defaults to val owner)\" },\n subject: { type: \"string\", description: \"Email subject\" },\n text: { type: \"string\", description: \"Plain text email body\" },\n html: { type: \"string\", description: \"HTML email body\" }\n },\n required: [\"subject\"]\n }\n },\n {\n name: \"openai_chat\",\n description: \"Generate text using OpenAI's chat completion API\",\n inputSchema: {\n type: \"object\",\n properties: {\n messages: {\n type: \"array\",\n description: \"Array of chat messages\",\n items: {\n type: \"object\",\n properties: {\n role: { type: \"string\", enum: [\"system\", \"user\", \"assistant\"] },\n content: { type: \"string\" }\n },\n required: [\"role\", \"content\"]\n }\n },\n model: { type: \"string\", default: \"gpt-4o-mini\", description: \"OpenAI model to use\" },\n max_tokens: { type: \"number\", description: \"Maximum tokens to generate\" },\n temperature: { type: \"number\", description: \"Sampling temperature\" }\n },\n required: [\"messages\"]\n }\n },\n {\n name: \"file_read\",\n description: \"Read a file from the Val Town project\",\n inputSchema: {\n type: \"object\",\n properties: {\n path: { type: \"string\", description: \"File path to read (e.g., '/frontend/index.html')\" }\n },\n required: [\"path\"]\n }\n },\n {\n name: \"file_list\",\n description: \"List all files in the Val Town project\",\n inputSchema: {\n type: \"object\",\n properties: {}\n }\n },\n {\n name: \"env_get\",\n description: \"Get an environment variable value\",\n inputSchema: {\n type: \"object\",\n properties: {\n key: { type: \"string\", description: \"Environment variable name\" }\n },\n required: [\"key\"]\n }\n }\n];\n\nexport async function executeTool(name: string, args: Record): Promise {\n try {\n switch (name) {\n case \"blob_get\":\n return await handleBlobGet(args);\n case \"blob_set\":\n return await handleBlobSet(args);\n case \"blob_list\":\n return await handleBlobList(args);\n case \"blob_delete\":\n return await handleBlobDelete(args);\n case \"sqlite_execute\":\n return await handleSqliteExecute(args);\n case \"email_send\":\n return await handleEmailSend(args);\n case \"openai_chat\":\n return await handleOpenAIChat(args);\n case \"file_read\":\n return await handleFileRead(args);\n case \"file_list\":\n return await handleFileList(args);\n case \"env_get\":\n return await handleEnvGet(args);\n default:\n throw new MCPException(MCP_ERRORS.TOOL_NOT_FOUND, `Tool not found: ${name}`);\n }\n } catch (error) {\n if (error instanceof MCPException) {\n throw error;\n }\n return {\n content: [{\n type: \"text\",\n text: `Error executing tool: ${error.message}`\n }],\n isError: true\n };\n }\n}\n\nasync function handleBlobGet(args: any): Promise {\n validateRequired(args, [\"key\"]);\n const key = sanitizeKey(args.key);\n const type = args.type || \"json\";\n \n try {\n const value = type === \"json\" ? await blob.getJSON(key) : await blob.get(key);\n return {\n content: [{\n type: \"text\",\n text: JSON.stringify({ key, value, type }, null, 2)\n }]\n };\n } catch (error) {\n return {\n content: [{\n type: \"text\",\n text: `Blob not found or error retrieving: ${key}`\n }],\n isError: true\n };\n }\n}\n\nasync function handleBlobSet(args: any): Promise {\n validateRequired(args, [\"key\", \"value\"]);\n const key = sanitizeKey(args.key);\n const type = args.type || \"json\";\n \n if (type === \"json\") {\n await blob.setJSON(key, args.value);\n } else {\n await blob.set(key, String(args.value));\n }\n \n return {\n content: [{\n type: \"text\",\n text: `Successfully stored data in blob: ${key}`\n }]\n };\n}\n\nasync function handleBlobList(args: any): Promise {\n const prefix = args.prefix || \"\";\n const keys = await blob.list(prefix);\n \n return {\n content: [{\n type: \"text\",\n text: JSON.stringify({ prefix, keys, count: keys.length }, null, 2)\n }]\n };\n}\n\nasync function handleBlobDelete(args: any): Promise {\n validateRequired(args, [\"key\"]);\n const key = sanitizeKey(args.key);\n \n await blob.delete(key);\n \n return {\n content: [{\n type: \"text\",\n text: `Successfully deleted blob: ${key}`\n }]\n };\n}\n\nasync function handleSqliteExecute(args: any): Promise {\n validateRequired(args, [\"query\"]);\n const { query, params = [] } = args;\n \n const result = await sqlite.execute(query, params);\n \n return {\n content: [{\n type: \"text\",\n text: JSON.stringify({ query, params, result }, null, 2)\n }]\n };\n}\n\nasync function handleEmailSend(args: any): Promise {\n validateRequired(args, [\"subject\"]);\n \n const emailOptions: any = {\n subject: args.subject\n };\n \n if (args.to) emailOptions.to = args.to;\n if (args.text) emailOptions.text = args.text;\n if (args.html) emailOptions.html = args.html;\n \n await email(emailOptions);\n \n return {\n content: [{\n type: \"text\",\n text: `Email sent successfully: ${args.subject}`\n }]\n };\n}\n\nasync function handleOpenAIChat(args: any): Promise {\n validateRequired(args, [\"messages\"]);\n \n const openai = new OpenAI();\n const options: any = {\n messages: args.messages,\n model: args.model || \"gpt-4o-mini\"\n };\n \n if (args.max_tokens) options.max_tokens = args.max_tokens;\n if (args.temperature !== undefined) options.temperature = args.temperature;\n \n const completion = await openai.chat.completions.create(options);\n \n return {\n content: [{\n type: \"text\",\n text: JSON.stringify({\n response: completion.choices[0]?.message?.content,\n usage: completion.usage,\n model: completion.model\n }, null, 2)\n }]\n };\n}\n\nasync function handleFileRead(args: any): Promise {\n validateRequired(args, [\"path\"]);\n \n try {\n const content = await readFile(args.path, import.meta.url);\n return {\n content: [{\n type: \"text\",\n text: JSON.stringify({ path: args.path, content }, null, 2)\n }]\n };\n } catch (error) {\n return {\n content: [{\n type: \"text\",\n text: `File not found or error reading: ${args.path}`\n }],\n isError: true\n };\n }\n}\n\nasync function handleFileList(args: any): Promise {\n try {\n const files = await listFiles(import.meta.url);\n return {\n content: [{\n type: \"text\",\n text: JSON.stringify({ files, count: files.length }, null, 2)\n }]\n };\n } catch (error) {\n return {\n content: [{\n type: \"text\",\n text: `Error listing files: ${error.message}`\n }],\n isError: true\n };\n }\n}\n\nasync function handleEnvGet(args: any): Promise {\n validateRequired(args, [\"key\"]);\n \n const value = Deno.env.get(args.key);\n \n return {\n content: [{\n type: \"text\",\n text: JSON.stringify({ \n key: args.key, \n exists: value !== undefined,\n value: value ? \"[REDACTED]\" : undefined // Don't expose actual values for security\n }, null, 2)\n }]\n };\n}",[],[149,213,215],"ff3dde0c-3c09-11f0-b76a-9e149126039e","server.ts","ff3ddea2-3c09-11f0-b76a-9e149126039e",6,["D",1748467408307],"/**\n * MCP Server Implementation\n */\n\nimport { MCPRequest, MCPResponse, MCPServerInfo } from \"./types.ts\";\nimport { TOOLS, executeTool } from \"./tools.ts\";\nimport { listResources, readResource } from \"./resources.ts\";\nimport { MCPException, MCP_ERRORS } from \"../../shared/utils.ts\";\n\nconst SERVER_INFO: MCPServerInfo = {\n name: \"val-town-mcp-server\",\n version: \"1.0.0\",\n protocolVersion: \"2024-11-05\",\n capabilities: {\n tools: {},\n resources: {},\n logging: {}\n }\n};\n\nexport async function handleMCPRequest(request: MCPRequest): Promise {\n try {\n // Validate JSON-RPC format\n if (request.jsonrpc !== \"2.0\") {\n throw new MCPException(MCP_ERRORS.INVALID_REQUEST, \"Invalid JSON-RPC version\");\n }\n\n const { method, params = {} } = request;\n\n let result: any;\n\n switch (method) {\n case \"initialize\":\n result = await handleInitialize(params);\n break;\n \n case \"tools/list\":\n result = await handleToolsList();\n break;\n \n case \"tools/call\":\n result = await handleToolsCall(params);\n break;\n \n case \"resources/list\":\n result = await handleResourcesList();\n break;\n \n case \"resources/read\":\n result = await handleResourcesRead(params);\n break;\n \n case \"ping\":\n result = { status: \"pong\" };\n break;\n \n default:\n throw new MCPException(MCP_ERRORS.METHOD_NOT_FOUND, `Method not found: ${method}`);\n }\n\n return {\n jsonrpc: \"2.0\",\n id: request.id,\n result\n };\n\n } catch (error) {\n const mcpError = error instanceof MCPException \n ? { code: error.code, message: error.message, data: error.data }\n : { code: MCP_ERRORS.INTERNAL_ERROR, message: error.message };\n\n return {\n jsonrpc: \"2.0\",\n id: request.id,\n error: mcpError\n };\n }\n}\n\nasync function handleInitialize(params: any): Promise {\n return {\n protocolVersion: SERVER_INFO.protocolVersion,\n capabilities: SERVER_INFO.capabilities,\n serverInfo: {\n name: SERVER_INFO.name,\n version: SERVER_INFO.version\n }\n };\n}\n\nasync function handleToolsList(): Promise {\n return {\n tools: TOOLS\n };\n}\n\nasync function handleToolsCall(params: any): Promise {\n if (!params.name) {\n throw new MCPException(MCP_ERRORS.INVALID_PARAMS, \"Missing tool name\");\n }\n\n const result = await executeTool(params.name, params.arguments || {});\n return result;\n}\n\nasync function handleResourcesList(): Promise {\n const resources = await listResources();\n return { resources };\n}\n\nasync function handleResourcesRead(params: any): Promise {\n if (!params.uri) {\n throw new MCPException(MCP_ERRORS.INVALID_PARAMS, \"Missing resource URI\");\n }\n\n return await readResource(params.uri);\n}\n\nexport function getServerInfo(): MCPServerInfo {\n return SERVER_INFO;\n}",[],[149,213,223],"a0aac5c0-3c0a-11f0-a5f8-9e149126039e",["D",1748467679130],[],[149,213,33],"d20c4dec-3c09-11f0-b62a-9e149126039e",["D",1748467332476],[166,167,168,169],[149,213],["D",1748467332476],[165,170,171],[149],["D",1748420544100],{"_98":97,"_105":101},{"_98":97,"_99":-5,"_100":101,"_18":56,"_102":103,"_104":25},{"_13":87,"_32":88,"_44":43,"_89":45,"_90":-5,"_91":-5,"_92":-5,"_93":-5,"_94":-5,"_95":46,"_96":97},"ctx",{"_80":-5,"_125":278,"_279":280,"_281":282,"_283":25,"_284":25,"_285":25,"_286":60,"_287":-5,"_288":-7,"_289":-7,"_290":64,"_291":25,"_292":25,"_293":-5,"_294":25,"_295":25,"_296":25,"_297":-5},"ENV",{"_249":250,"_251":252,"_253":88,"_254":255,"_256":257,"_258":259,"_260":261,"_262":263,"_264":265,"_266":267,"_268":269,"_270":271,"_272":273,"_274":275,"_276":277},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","RENDER_GIT_COMMIT","e87eb04e707cf64e7e532c8e8ec395f209e17f15","RENDER_GIT_BRANCH","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","CLOUDFLARE_TURNSTILE_SITE_KEY","0x4AAAAAACtaIZJH7s9rBMZ6","GOOGLE_CLIENT_ID","875989696899-jtsqkhlbdv5jrlsk8631p7ipjg3c6o62.apps.googleusercontent.com","STRIPE_PUBLISHABLE_KEY","pk_live_51N2zvWEpZTTLipIkVEwXrUG9AT0yeOOEYxszarZT1jpsZV58Ly6wlg3SltZpHN26CUalOBmUSY7adQRQiSkCZz2500qSXNkf8Y","API_URL","https://api.val.town",[],"preferencesKeybindings","default","preferencesTheme","light","preferencesFixers","preferencesCopilot","preferencesSelectionAi","preferencesCloseBrackets","preferencesChatPanelState","preferencesDprint","preferencesDenofmt","notificationCount","flagDenols","isBusinessOrgMember","businessOrgHandle","isBusinessOrgAdmin","isHigherTownieTier","navCollapsed","currentOrgId"]

Diff · v10