\n \n\n",[],[218,220],"c93d9f84-3c0b-11f0-a847-9e149126039e","MCPClient.tsx","c93da01a-3c0b-11f0-a847-9e149126039e","e95b85d1-4cb0-43d5-86c9-1fe92c0d6881",17,["D",1748468176700],"/** @jsxImportSource https://esm.sh/react@18.2.0 */\n\n/**\n * MCP Client for communicating with the Val Town MCP Server\n */\nexport class MCPClient {\n private baseUrl: string;\n private requestId: number = 1;\n\n constructor(baseUrl: string) {\n this.baseUrl = baseUrl;\n }\n\n private async makeRequest(method: string, params?: any): Promise {\n const request = {\n jsonrpc: \"2.0\",\n id: this.requestId++,\n method,\n ...(params && { params })\n };\n\n const response = await fetch(this.baseUrl, {\n method: 'POST',\n headers: {\n 'Content-Type': 'application/json',\n },\n body: JSON.stringify(request)\n });\n\n if (!response.ok) {\n throw new Error(`HTTP error! status: ${response.status}`);\n }\n\n const data = await response.json();\n \n if (data.error) {\n throw new Error(`MCP Error: ${data.error.message}`);\n }\n\n return data.result;\n }\n\n async initialize(): Promise {\n return this.makeRequest('initialize', {});\n }\n\n async listTools(): Promise {\n const result = await this.makeRequest('tools/list');\n return result.tools || [];\n }\n\n async callTool(name: string, arguments_: any): Promise {\n return this.makeRequest('tools/call', {\n name,\n arguments: arguments_\n });\n }\n\n async listResources(): Promise {\n const result = await this.makeRequest('resources/list');\n return result.resources || [];\n }\n\n async readResource(uri: string): Promise {\n return this.makeRequest('resources/read', { uri });\n }\n\n async ping(): Promise {\n return this.makeRequest('ping');\n }\n}",[],[218,236,228],"components","406eb4f4-3cd8-11f0-8bd2-9e149126039e","ChatInterface.tsx","c29dafca-3c0b-11f0-99d2-9e149126039e",["D",1748555993999],3,"/** @jsxImportSource https://esm.sh/react@18.2.0 */\nimport React, { useState, useRef, useEffect } from \"https://esm.sh/react@18.2.0?deps=react@18.2.0\";\nimport { Message } from \"./App.tsx\";\n\ninterface ChatInterfaceProps {\n messages: Message[];\n onSendMessage: (content: string) => void;\n isLoading: boolean;\n availableTools: any[];\n}\n\nexport function ChatInterface({ messages, onSendMessage, isLoading, availableTools }: ChatInterfaceProps) {\n const [input, setInput] = useState('');\n const messagesEndRef = useRef(null);\n\n const scrollToBottom = () => {\n messagesEndRef.current?.scrollIntoView({ behavior: \"smooth\" });\n };\n\n useEffect(() => {\n scrollToBottom();\n }, [messages]);\n\n const handleSubmit = (e: React.FormEvent) => {\n e.preventDefault();\n if (input.trim() && !isLoading) {\n onSendMessage(input.trim());\n setInput('');\n }\n };\n\n const formatTimestamp = (date: Date) => {\n return date.toLocaleTimeString([], { hour: '2-digit', minute: '2-digit' });\n };\n\n const renderMessageContent = (message: Message) => {\n if (message.role === 'assistant' && message.toolCalls) {\n return (\n

\n {/* Regular content */}\n {message.content && (\n

\n {message.content.split('\\n').map((line, i) => (\n

{line}

\n ))}\n

\n )}\n \n {/* Tool calls */}\n {message.toolCalls.map((toolCall, index) => (\n

\n 🔧 Tool Call: {toolCall.name}\n

\n \n

\n Arguments:\n

\n                    {JSON.stringify(toolCall.arguments, null, 2)}\n

\n \n {toolCall.result && (\n

\n Result:\n

\n                      {JSON.stringify(toolCall.result, null, 2)}\n

\n )}\n \n {toolCall.error && (\n

\n Error:\n

\n                      {toolCall.error}\n

\n )}\n

\n ))}\n

\n );\n }\n\n return (\n

\n {message.content.split('\\n').map((line, i) => (\n

{line}

\n ))}\n

\n );\n };\n\n const getMessageIcon = (role: string) => {\n switch (role) {\n case 'user': return '👤';\n case 'assistant': return '🤖';\n case 'system': return 'ℹ️';\n default: return '💬';\n }\n };\n\n const getMessageBgColor = (role: string) => {\n switch (role) {\n case 'user': return 'bg-blue-50 border-blue-200';\n case 'assistant': return 'bg-green-50 border-green-200';\n case 'system': return 'bg-yellow-50 border-yellow-200';\n default: return 'bg-gray-50 border-gray-200';\n }\n };\n\n return (\n

\n {/* Messages */}\n

\n {messages.map((message) => (\n \n

\n {getMessageIcon(message.role)}\n {message.role}\n

\n \n {formatTimestamp(message.timestamp)}\n \n

\n {renderMessageContent(message)}\n

\n ))}\n \n {isLoading && (\n

\n 🤖\n Assistant\n

\n Thinking...\n

\n )}\n \n

\n\n {/* Input form */}\n

\n setInput(e.target.value)}\n placeholder=\"Ask me anything about Val Town or request tool usage...\"\n disabled={isLoading}\n className=\"flex-1 px-3 py-2 border border-gray-300 rounded-md focus:outline-none focus:ring-2 focus:ring-blue-500 focus:border-transparent disabled:bg-gray-100\"\n />\n \n {isLoading ? '⏳' : 'Send'}\n \n \n\n {/* Example prompts */}\n

Try these example prompts:

\n {[\n \"List all available tools\",\n \"Store some data in blob storage\",\n \"Query the SQLite database\",\n \"Send a test email\",\n \"Read a project file\",\n \"Get an environment variable\"\n ].map((prompt, index) => (\n !isLoading && setInput(prompt)}\n disabled={isLoading}\n className=\"px-3 py-1 text-xs bg-gray-200 text-gray-700 rounded hover:bg-gray-300 disabled:opacity-50 disabled:cursor-not-allowed transition-colors\"\n >\n {prompt}\n \n ))}\n

\n );\n}",[],[218,236,238],"406ea978-3cd8-11f0-8bd2-9e149126039e","App.tsx","a811d0a0-3c0b-11f0-a66f-9e149126039e",["D",1748555993999],9,"/** @jsxImportSource https://esm.sh/react@18.2.0 */\nimport React, { useEffect, useRef, useState } from \"https://esm.sh/react@18.2.0?deps=react@18.2.0\";\nimport { ApiKeyInput } from \"./ApiKeyInput.tsx\";\nimport { ChatInterface } from \"./ChatInterface.tsx\";\nimport { MCPClient } from \"./MCPClient.tsx\";\n\nexport interface Message {\n id: string;\n role: \"user\" | \"assistant\" | \"system\";\n content: string;\n timestamp: Date;\n toolCalls?: ToolCall[];\n mcpResponses?: any[];\n}\n\nexport interface ToolCall {\n id: string;\n name: string;\n arguments: any;\n result?: any;\n error?: string;\n}\n\nexport function App() {\n const [apiKey, setApiKey] = useState(\"\");\n const [messages, setMessages] = useState([]);\n const [isLoading, setIsLoading] = useState(false);\n const [mcpClient, setMcpClient] = useState(null);\n const [availableTools, setAvailableTools] = useState([]);\n\n // Initialize MCP client and load API key from localStorage\n useEffect(() => {\n const savedApiKey = localStorage.getItem(\"anthropic_api_key\");\n if (savedApiKey) {\n setApiKey(savedApiKey);\n }\n\n // Initialize MCP client\n const client = new MCPClient(\"/mcp\");\n setMcpClient(client);\n\n // Load available tools\n client.listTools().then(tools => {\n setAvailableTools(tools);\n console.log(\"Available MCP tools:\", tools);\n }).catch(err => {\n console.error(\"Failed to load MCP tools:\", err);\n });\n\n // Add welcome message\n setMessages([{\n id: \"1\",\n role: \"system\",\n content:\n \"Welcome to the Val Town MCP Client Demo! This chat interface connects to Claude via the Anthropic API and uses the Val Town MCP server to execute tools. Enter your Anthropic API key to get started.\",\n timestamp: new Date(),\n }]);\n }, []);\n\n const handleApiKeyChange = (key: string) => {\n setApiKey(key);\n localStorage.setItem(\"anthropic_api_key\", key);\n };\n\n const sendMessage = async (content: string) => {\n if (!apiKey.trim()) {\n alert(\"Please enter your Anthropic API key first\");\n return;\n }\n\n if (!mcpClient) {\n alert(\"MCP client not initialized\");\n return;\n }\n\n const userMessage: Message = {\n id: Date.now().toString(),\n role: \"user\",\n content,\n timestamp: new Date(),\n };\n\n setMessages(prev => [...prev, userMessage]);\n setIsLoading(true);\n\n try {\n // Prepare system message with MCP tools\n const systemMessage = `You are an AI assistant with access to Val Town's capabilities through MCP tools. \n\nAvailable tools:\n${availableTools.map(tool => `- ${tool.name}: ${tool.description}`).join(\"\\n\")}\n\nWhen you need to use these tools, I will execute them for you and provide the results. Be helpful and use the tools when appropriate to assist the user.`;\n\n // Call Anthropic API\n const response = await fetch(\"https://api.anthropic.com/v1/messages\", {\n method: \"POST\",\n headers: {\n \"Content-Type\": \"application/json\",\n \"x-api-key\": apiKey,\n \"anthropic-version\": \"2023-06-01\",\n \"anthropic-dangerous-direct-browser-access\": \"true\",\n \"anthropic-beta\": \"mcp-client-2025-04-04\",\n },\n body: JSON.stringify({\n model: \"claude-3-5-sonnet-20241022\",\n max_tokens: 1024,\n system: systemMessage,\n messages: messages\n .filter(m => m.role !== \"system\")\n .map(m => ({\n role: m.role,\n content: m.content,\n }))\n .concat([{ role: \"user\", content }]),\n mcp_servers: [{\n \"type\": \"url\",\n \"url\": \"https://c15r--81c497c63c0a11f081e29e149126039e.web.val.run/mcp\",\n \"name\": \"val-town-mcp\",\n \"authorization_token\": \"YOUR_TOKEN\",\n }],\n }),\n });\n\n if (!response.ok) {\n const errorData = await response.json();\n throw new Error(`Anthropic API error: ${errorData.error?.message || response.statusText}`);\n }\n\n const data = await response.json();\n\n // Handle tool calls\n let toolCalls: ToolCall[] = [];\n let mcpResponses: any[] = [];\n\n if (data.content) {\n for (const contentBlock of data.content) {\n if (contentBlock.type === \"tool_use\") {\n const toolCall: ToolCall = {\n id: contentBlock.id,\n name: contentBlock.name,\n arguments: contentBlock.input,\n };\n\n try {\n // Execute tool via MCP\n const result = await mcpClient.callTool(contentBlock.name, contentBlock.input);\n toolCall.result = result;\n mcpResponses.push(result);\n } catch (error) {\n toolCall.error = error.message;\n mcpResponses.push({ error: error.message });\n }\n\n toolCalls.push(toolCall);\n }\n }\n }\n\n // Create assistant message\n const assistantMessage: Message = {\n id: (Date.now() + 1).toString(),\n role: \"assistant\",\n content: data.content\n ?.filter((block: any) => block.type === \"text\")\n ?.map((block: any) => block.text)\n ?.join(\"\\n\") || \"No response content\",\n timestamp: new Date(),\n toolCalls: toolCalls.length > 0 ? toolCalls : undefined,\n mcpResponses: mcpResponses.length > 0 ? mcpResponses : undefined,\n };\n\n setMessages(prev => [...prev, assistantMessage]);\n } catch (error) {\n console.error(\"Error sending message:\", error);\n const errorMessage: Message = {\n id: (Date.now() + 2).toString(),\n role: \"system\",\n content: `Error: ${error.message}`,\n timestamp: new Date(),\n };\n setMessages(prev => [...prev, errorMessage]);\n } finally {\n setIsLoading(false);\n }\n };\n\n const clearChat = () => {\n setMessages([{\n id: \"1\",\n role: \"system\",\n content: \"Chat cleared. You can start a new conversation.\",\n timestamp: new Date(),\n }]);\n };\n\n return (\n

\n 🏔️ Val Town MCP Client Demo\n

\n Chat with Claude using Val Town's MCP server capabilities\n

\n\n

\n \n\n

Chat Interface

\n \n Clear Chat\n \n

\n\n \n

\n\n {availableTools.length > 0 && (\n

\n Available MCP Tools ({availableTools.length})\n

\n {availableTools.map((tool, index) => (\n

{tool.name}

{tool.description}

\n ))}\n

\n )}\n

\n\n \n

\n );\n}",[],[218,236,246],"406e9f82-3cd8-11f0-8bd2-9e149126039e","ApiKeyInput.tsx","b0d8fa42-3c0b-11f0-af64-9e149126039e",["D",1748555993999],"/** @jsxImportSource https://esm.sh/react@18.2.0 */\nimport React, { useState } from \"https://esm.sh/react@18.2.0?deps=react@18.2.0\";\n\ninterface ApiKeyInputProps {\n apiKey: string;\n onApiKeyChange: (key: string) => void;\n}\n\nexport function ApiKeyInput({ apiKey, onApiKeyChange }: ApiKeyInputProps) {\n const [isVisible, setIsVisible] = useState(false);\n const [tempKey, setTempKey] = useState(apiKey);\n\n const handleSave = () => {\n onApiKeyChange(tempKey);\n };\n\n const handleClear = () => {\n setTempKey('');\n onApiKeyChange('');\n localStorage.removeItem('anthropic_api_key');\n };\n\n return (\n

🔑 Anthropic API Key

\n \n

\n \n Enter your Anthropic API Key\n \n

\n setTempKey(e.target.value)}\n placeholder=\"sk-ant-api03-...\"\n className=\"w-full px-3 py-2 border border-gray-300 rounded-md focus:outline-none focus:ring-2 focus:ring-blue-500 focus:border-transparent\"\n />\n setIsVisible(!isVisible)}\n className=\"absolute right-3 top-1/2 transform -translate-y-1/2 text-gray-500 hover:text-gray-700\"\n >\n {isVisible ? '🙈' : '👁️'}\n \n

\n \n Save\n \n \n Clear\n \n

\n\n

\n Status:{' '}\n \n {apiKey ? '✅ API key configured' : '❌ No API key set'}\n \n

\n Your API key is stored locally in your browser and sent directly to Anthropic's API.\n

\n Get your API key from{' '}\n \n Anthropic Console\n \n

\n );\n}",[],[218,236,254],"a81201b0-3c0b-11f0-a66f-9e149126039e",14,["D",1748468121047],[177,178,179,180],[218,236],"902fd9fa-3c0b-11f0-8e65-9e149126039e",12,["D",1748468080979],[176,181,182],[218],"2e00fb06-3cd8-11f0-97cc-9e149126039e","index.ts","52a0890e-2351-4d07-b870-7d21fa9d4b87",37,["D",1748555963084],"http","/**\n * Val Town MCP Server - Main HTTP Entry Point\n */\n\nimport { Hono } from \"https://esm.sh/hono@3.11.7\";\nimport { readFile, serveFile } from \"https://esm.town/v/std/utils@85-main/index.ts\";\nimport { getServerInfo, handleMCPRequest } 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// Serve frontend files\napp.get(\"/frontend/*\", c => serveFile(c.req.path, import.meta.url));\napp.get(\"/shared/*\", c => serveFile(c.req.path, import.meta.url));\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// Demo/Test page with MCP client\napp.get(\"/demo\", async (c) => {\n const html = await readFile(\"/frontend/index.html\", import.meta.url);\n return c.html(html);\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

Demo

\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",[],[280,271],"backend","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",[],[280,196],"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}",[],[280,296,289],"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}",[],[280,296,298],"ff3dde0c-3c09-11f0-b76a-9e149126039e","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}",[],[280,296,188],"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}",[],[280,296,313],"d20c4dec-3c09-11f0-b62a-9e149126039e",["D",1748467332476],[169,170,171,172],[280,296],"d20c4bc6-3c09-11f0-b62a-9e149126039e",["D",1748467332476],[168,173,174],[280],["D",1748420544100],{"_11":12,"_122":70},{"_11":12,"_118":-5,"_69":70,"_31":68,"_119":120,"_121":30},{"_39":109,"_13":16,"_33":36,"_110":74,"_111":-5,"_112":-5,"_113":-5,"_114":-5,"_115":-5,"_116":14,"_117":12},"ctx",{"_52":-5,"_141":365,"_366":367,"_368":369,"_370":30,"_371":30,"_372":30,"_373":24,"_374":-5,"_375":-7,"_376":-7,"_377":26,"_378":30,"_379":30,"_380":-5,"_381":30,"_382":30,"_383":30,"_384":-5},"ENV",{"_336":337,"_338":339,"_340":16,"_341":342,"_343":344,"_345":346,"_347":348,"_349":350,"_351":352,"_353":354,"_355":356,"_357":358,"_359":360,"_361":362,"_363":364},"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"]

History · shared