[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_266":267,"_268":269},"routes/_app.x.$handle.$name",{"_101":100,"_32":49,"_109":91,"_27":110,"_13":14,"_111":-5,"_11":112,"_113":114,"_115":116,"_117":118,"_119":120,"_21":-5,"_121":-5,"_122":-5,"_123":25,"_124":125,"_126":63,"_127":-5,"_128":-5,"_129":130},"routes/_app.x.$handle.$name.branch.$branch.version.$version.diff",{"_11":12,"_13":14,"_15":16,"_17":-5,"_18":-5},"project",{"_47":48,"_32":49,"_36":50,"_51":-5,"_52":25,"_53":54,"_55":54,"_56":57,"_58":-5,"_18":59,"_60":61,"_62":63,"_64":63,"_65":-5,"_66":67,"_68":69,"_70":-5,"_71":-5,"_72":-5,"_73":-5,"_74":75,"_76":75,"_77":78,"_79":78,"_80":78,"_81":75,"_82":75,"_83":84,"_85":86,"_87":88,"_89":25},"version",12,"changes",[19,20],"aiChatInfo","userId",{"_21":41,"_23":-7,"_24":25,"_26":25,"_27":42,"_29":42},{"_21":22,"_23":-7,"_24":25,"_26":25,"_27":28,"_29":28},"file",{"_30":31,"_32":28,"_33":34,"_35":-5,"_36":37,"_38":14,"_39":40,"_24":25},"previous","deleted",false,"deletedHere","path","frontend","latestPath","fileId","fd0ed52a-80e3-4bad-bfab-b43c1d460782","name","fileType","directory","content","createdAt",["D",1748468080979],"branchVersion","branchId","e1ff5798-3b9c-11f0-96f0-9e149126039e",{"_30":43,"_32":44,"_33":21,"_35":45,"_36":46,"_38":14,"_39":40,"_24":25},"frontend/index.html","902fd09a-3c0b-11f0-8e65-9e149126039e","index.html","\n\n\n \n \n Val Town MCP Client Demo\n \n \n\n\n

\n \n\n",["D",1748468080979],"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",{"_101":100,"_108":104},"org",{"_101":100,"_102":-5,"_103":104,"_18":59,"_105":106,"_107":25},"branch",{"_13":90,"_32":91,"_47":40,"_92":48,"_93":-5,"_94":-5,"_95":-5,"_96":-5,"_97":-5,"_98":49,"_99":100},"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",{"_47":48,"_32":49,"_36":262,"_51":-5,"_52":25,"_53":54,"_55":54,"_56":57,"_58":-5,"_18":59,"_60":61,"_62":63,"_64":63,"_65":-5,"_66":67,"_68":69,"_70":-5,"_71":-5,"_72":-5,"_73":-5,"_74":75,"_76":75,"_77":78,"_79":78,"_80":78,"_81":75,"_82":75,"_83":263,"_85":264,"_87":265,"_89":25},"tree",[171,179,181,183],"files",[171,172,173,174,175,176,177,178,179,180,181,182,183],"counts",{"_161":67,"_162":142,"_163":67,"_164":165,"_166":167},"contents",[131,132,133,134],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},{"_47":155,"_32":156,"_30":157,"_138":-5,"_39":40,"_38":158,"_140":63,"_36":159,"_13":67,"_33":34,"_35":-5,"_24":25,"_144":-5,"_27":160},{"_47":152,"_32":28,"_30":31,"_138":-5,"_39":40,"_38":14,"_140":63,"_36":153,"_13":67,"_33":34,"_35":-5,"_24":25,"_144":-5,"_27":154},{"_47":146,"_32":147,"_30":148,"_138":-5,"_39":40,"_38":149,"_140":63,"_36":150,"_13":67,"_33":34,"_35":-5,"_24":25,"_144":-5,"_27":151},{"_47":135,"_32":136,"_30":137,"_138":-5,"_39":40,"_38":139,"_140":63,"_36":141,"_13":142,"_33":21,"_35":143,"_24":25,"_144":-5,"_27":145},"aa44d602-3c0a-11f0-8162-9e149126039e","README.md","c9000cca-3c09-11f0-a57a-9e149126039e","parentId",11,"latest",["D",1748467695240],1,"# 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### Endpoints\n\n- **Main Interface**: `GET /` - Web interface with documentation\n- **MCP Protocol**: `POST /mcp` - JSON-RPC 2.0 endpoint for MCP requests\n- **Health Check**: `GET /health` - Server health status\n- **API Documentation**: `GET /api/docs` - Complete API documentation in JSON format\n\n### Example MCP Requests\n\n```json\n// Initialize connection\n{\n \"jsonrpc\": \"2.0\",\n \"id\": 1,\n \"method\": \"initialize\",\n \"params\": {}\n}\n\n// List available tools\n{\n \"jsonrpc\": \"2.0\",\n \"id\": 2,\n \"method\": \"tools/list\"\n}\n\n// Call a tool\n{\n \"jsonrpc\": \"2.0\",\n \"id\": 3,\n \"method\": \"tools/call\",\n \"params\": {\n \"name\": \"blob_set\",\n \"arguments\": {\n \"key\": \"my-data\",\n \"value\": {\"hello\": \"world\"}\n }\n }\n}\n\n// List resources\n{\n \"jsonrpc\": \"2.0\",\n \"id\": 4,\n \"method\": \"resources/list\"\n}\n```\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",[136],"cd9d2b82-3c09-11f0-8c8b-9e149126039e","shared","a0461c89-f398-426b-afac-535542e9505b",2,["D",1748467325043],[147],"902fd9fa-3c0b-11f0-8e65-9e149126039e",["D",1748468080979],[28],"d20c4bc6-3c09-11f0-b62a-9e149126039e","backend","52a0890e-2351-4d07-b870-7d21fa9d4b87",3,["D",1748467332476],[156],"pulls","branches","forks","envVars",{"_168":67,"_170":67},"connections",{"_168":67,"_169":67},"count","unfilledCount","emptyCount",{"_47":155,"_32":156,"_30":157,"_138":-5,"_39":40,"_38":158,"_140":63,"_36":259,"_13":67,"_33":34,"_35":-5,"_24":25,"_144":-5,"_185":260,"_27":261},{"_47":255,"_32":230,"_30":225,"_138":157,"_39":40,"_38":158,"_140":63,"_36":256,"_13":67,"_33":34,"_35":-5,"_24":25,"_144":-5,"_185":257,"_27":258},{"_47":247,"_32":248,"_30":249,"_138":225,"_39":40,"_38":250,"_140":63,"_36":251,"_13":142,"_33":192,"_35":252,"_24":25,"_144":-5,"_185":253,"_27":254},{"_47":239,"_32":240,"_30":241,"_138":225,"_39":40,"_38":242,"_140":63,"_36":243,"_13":67,"_33":192,"_35":244,"_24":25,"_144":-5,"_185":245,"_27":246},{"_47":231,"_32":232,"_30":233,"_138":225,"_39":40,"_38":234,"_140":63,"_36":235,"_13":67,"_33":192,"_35":236,"_24":25,"_144":-5,"_185":237,"_27":238},{"_47":222,"_32":223,"_30":224,"_138":225,"_39":40,"_38":158,"_140":63,"_36":226,"_13":67,"_33":192,"_35":227,"_24":25,"_144":-5,"_185":228,"_27":229},{"_47":215,"_32":136,"_30":216,"_138":157,"_39":40,"_38":217,"_140":63,"_36":218,"_13":67,"_33":21,"_35":219,"_24":25,"_144":-5,"_185":220,"_27":221},{"_47":206,"_32":207,"_30":61,"_138":157,"_39":40,"_38":208,"_140":25,"_36":209,"_13":142,"_33":210,"_35":211,"_24":25,"_144":212,"_185":213,"_27":214},{"_47":152,"_32":28,"_30":31,"_138":-5,"_39":40,"_38":14,"_140":63,"_36":203,"_13":67,"_33":34,"_35":-5,"_24":25,"_144":-5,"_185":204,"_27":205},{"_47":199,"_32":44,"_30":43,"_138":31,"_39":40,"_38":14,"_140":25,"_36":200,"_13":67,"_33":21,"_35":45,"_24":25,"_144":-5,"_185":201,"_27":202},{"_47":146,"_32":147,"_30":148,"_138":-5,"_39":40,"_38":149,"_140":63,"_36":196,"_13":67,"_33":34,"_35":-5,"_24":25,"_144":-5,"_185":197,"_27":198},{"_47":188,"_32":189,"_30":190,"_138":148,"_39":40,"_38":149,"_140":63,"_36":191,"_13":67,"_33":192,"_35":193,"_24":25,"_144":-5,"_185":194,"_27":195},{"_47":135,"_32":136,"_30":137,"_138":-5,"_39":40,"_38":139,"_140":63,"_36":184,"_13":142,"_33":21,"_35":143,"_24":25,"_144":-5,"_185":186,"_27":187},["D",1748467695240],"children",[],[136],"cd9d0fc6-3c09-11f0-8c8b-9e149126039e","utils.ts","cd9d1098-3c09-11f0-8c8b-9e149126039e",["D",1748467325043],"script","/**\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}",[],[147,189],["D",1748467325043],[182],[147],"902fcfc8-3c0b-11f0-8e65-9e149126039e",["D",1748468080979],[],[28,44],["D",1748468080979],[180],[28],"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",[],[156,207],"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",[],[156,136],"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}",[],[156,230,223],"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}",[],[156,230,232],"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}",[],[156,230,240],"a0aac5c0-3c0a-11f0-a5f8-9e149126039e","resources.ts","f6e5ab04-3c09-11f0-92ed-9e149126039e",10,["D",1748467679130],"/**\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}",[],[156,230,248],"d20c4dec-3c09-11f0-b62a-9e149126039e",["D",1748467332476],[173,174,175,176],[156,230],["D",1748467332476],[172,177,178],[156],["D",1748420544100],{"_101":100,"_108":104},{"_101":100,"_102":-5,"_103":104,"_18":59,"_105":106,"_107":25},{"_13":90,"_32":91,"_47":40,"_92":48,"_93":-5,"_94":-5,"_95":-5,"_96":-5,"_97":-5,"_98":49,"_99":100},"ctx",{"_83":-5,"_128":299,"_300":301,"_302":303,"_304":25,"_305":25,"_306":25,"_307":63,"_308":-5,"_309":-7,"_310":-7,"_311":67,"_312":25,"_313":25,"_314":-5,"_315":25,"_316":25,"_317":25,"_318":-5},"ENV",{"_270":271,"_272":273,"_274":91,"_275":276,"_277":278,"_279":280,"_281":282,"_283":284,"_285":286,"_287":288,"_289":290,"_291":292,"_293":294,"_295":296,"_297":298},"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 · v12