[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_233":234,"_235":236},"routes/_app.x.$handle.$name",{"_95":94,"_31":43,"_103":85,"_26":104,"_13":14,"_105":-5,"_11":106,"_107":108,"_109":110,"_111":112,"_113":114,"_20":-5,"_115":-5,"_116":-5,"_117":24,"_118":119,"_120":24,"_121":-5,"_122":-5,"_123":124},"routes/_app.x.$handle.$name.branch.$branch.version.$version.diff",{"_11":12,"_13":14,"_15":16,"_17":-5,"_18":-5},"project",{"_41":42,"_31":43,"_36":44,"_45":-5,"_46":24,"_47":48,"_49":48,"_50":51,"_52":-5,"_18":53,"_54":55,"_56":57,"_58":57,"_59":-5,"_60":61,"_62":63,"_64":-5,"_65":-5,"_66":-5,"_67":-5,"_68":69,"_70":69,"_71":72,"_73":72,"_74":72,"_75":69,"_76":69,"_77":78,"_79":80,"_81":82,"_83":24},"version",7,"changes",[19],"aiChatInfo","userId",{"_20":21,"_22":-7,"_23":24,"_25":24,"_26":27,"_28":27},"file",{"_29":30,"_31":32,"_33":20,"_34":35,"_36":37,"_38":14,"_39":40,"_23":24},"previous","deleted",false,"deletedHere","path","backend/README.md","latestPath","fileId","05b2c7f2-3c0a-11f0-a67a-9e149126039e","name","README.md","fileType","content","# 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","createdAt",["D",1748467419138],"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",{"_95":94,"_102":98},"org",{"_95":94,"_96":-5,"_97":98,"_18":53,"_99":100,"_101":24},"branch",{"_13":84,"_31":85,"_41":40,"_86":42,"_87":-5,"_88":-5,"_89":-5,"_90":-5,"_91":-5,"_92":43,"_93":94},"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",{"_41":42,"_31":43,"_36":229,"_45":-5,"_46":24,"_47":48,"_49":48,"_50":51,"_52":-5,"_18":53,"_54":55,"_56":57,"_58":57,"_59":-5,"_60":61,"_62":63,"_64":-5,"_65":-5,"_66":-5,"_67":-5,"_68":69,"_70":69,"_71":72,"_73":72,"_74":72,"_75":69,"_76":69,"_77":230,"_79":231,"_81":232,"_83":24},"tree",[160,167,169],"files",[160,161,162,163,164,165,166,167,168,169],"counts",{"_150":61,"_151":131,"_152":61,"_153":154,"_155":156},"contents",[125,126,127],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},{"_41":144,"_31":145,"_29":146,"_130":-5,"_39":40,"_38":147,"_132":57,"_36":148,"_13":61,"_33":142,"_34":-5,"_23":24,"_135":-5,"_26":149},{"_41":137,"_31":138,"_29":139,"_130":-5,"_39":40,"_38":140,"_132":57,"_36":141,"_13":61,"_33":142,"_34":-5,"_23":24,"_135":-5,"_26":143},{"_41":128,"_31":32,"_29":129,"_130":-5,"_39":40,"_38":131,"_132":24,"_36":133,"_13":61,"_33":20,"_34":134,"_23":24,"_135":-5,"_26":136},"c9000c16-3c09-11f0-a57a-9e149126039e","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",[32],"cd9d2b82-3c09-11f0-8c8b-9e149126039e","shared","a0461c89-f398-426b-afac-535542e9505b",2,["D",1748467325043],"directory",[138],"d20c4bc6-3c09-11f0-b62a-9e149126039e","backend","52a0890e-2351-4d07-b870-7d21fa9d4b87",3,["D",1748467332476],[145],"pulls","branches","forks","envVars",{"_157":61,"_159":61},"connections",{"_157":61,"_158":61},"count","unfilledCount","emptyCount",{"_41":144,"_31":145,"_29":146,"_130":-5,"_39":40,"_38":147,"_132":57,"_36":226,"_13":61,"_33":142,"_34":-5,"_23":24,"_135":-5,"_171":227,"_26":228},{"_41":222,"_31":197,"_29":192,"_130":146,"_39":40,"_38":147,"_132":57,"_36":223,"_13":61,"_33":142,"_34":-5,"_23":24,"_135":-5,"_171":224,"_26":225},{"_41":214,"_31":215,"_29":216,"_130":192,"_39":40,"_38":217,"_132":24,"_36":218,"_13":61,"_33":178,"_34":219,"_23":24,"_135":-5,"_171":220,"_26":221},{"_41":206,"_31":207,"_29":208,"_130":192,"_39":40,"_38":209,"_132":57,"_36":210,"_13":61,"_33":178,"_34":211,"_23":24,"_135":-5,"_171":212,"_26":213},{"_41":198,"_31":199,"_29":200,"_130":192,"_39":40,"_38":201,"_132":57,"_36":202,"_13":61,"_33":178,"_34":203,"_23":24,"_135":-5,"_171":204,"_26":205},{"_41":189,"_31":190,"_29":191,"_130":192,"_39":40,"_38":147,"_132":57,"_36":193,"_13":61,"_33":178,"_34":194,"_23":24,"_135":-5,"_171":195,"_26":196},{"_41":185,"_31":32,"_29":30,"_130":146,"_39":40,"_38":14,"_132":57,"_36":186,"_13":61,"_33":20,"_34":35,"_23":24,"_135":-5,"_171":187,"_26":188},{"_41":137,"_31":138,"_29":139,"_130":-5,"_39":40,"_38":140,"_132":57,"_36":182,"_13":61,"_33":142,"_34":-5,"_23":24,"_135":-5,"_171":183,"_26":184},{"_41":174,"_31":175,"_29":176,"_130":139,"_39":40,"_38":140,"_132":57,"_36":177,"_13":61,"_33":178,"_34":179,"_23":24,"_135":-5,"_171":180,"_26":181},{"_41":128,"_31":32,"_29":129,"_130":-5,"_39":40,"_38":131,"_132":24,"_36":170,"_13":61,"_33":20,"_34":134,"_23":24,"_135":-5,"_171":172,"_26":173},["D",1748467317303],"children",[],[32],"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}",[],[138,175],["D",1748467325043],[168],[138],"05b2c752-3c0a-11f0-a67a-9e149126039e",["D",1748467419138],[],[145,32],"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}",[],[145,197,190],"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}",[],[145,197,199],"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}",[],[145,197,207],"f6e5aa14-3c09-11f0-92ed-9e149126039e","resources.ts","f6e5ab04-3c09-11f0-92ed-9e149126039e",5,["D",1748467394305],"/**\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}",[],[145,197,215],"d20c4dec-3c09-11f0-b62a-9e149126039e",["D",1748467332476],[162,163,164,165],[145,197],["D",1748467332476],[161,166],[145],["D",1748420544100],{"_95":94,"_102":98},{"_95":94,"_96":-5,"_97":98,"_18":53,"_99":100,"_101":24},{"_13":84,"_31":85,"_41":40,"_86":42,"_87":-5,"_88":-5,"_89":-5,"_90":-5,"_91":-5,"_92":43,"_93":94},"ctx",{"_77":-5,"_122":266,"_267":268,"_269":270,"_271":24,"_272":24,"_273":24,"_274":57,"_275":-5,"_276":-7,"_277":-7,"_278":61,"_279":24,"_280":24,"_281":-5,"_282":24,"_283":24,"_284":24,"_285":-5},"ENV",{"_237":238,"_239":240,"_241":85,"_242":243,"_244":245,"_246":247,"_248":249,"_250":251,"_252":253,"_254":255,"_256":257,"_258":259,"_260":261,"_262":263,"_264":265},"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 · v7