Anthropic Chat with MCP

[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_283":284,"_285":286},"routes/_app.x.$handle.$name",{"_96":95,"_32":45,"_104":86,"_27":105,"_13":14,"_106":-5,"_11":107,"_108":109,"_110":111,"_112":113,"_114":115,"_20":-5,"_116":-5,"_117":-5,"_118":25,"_119":120,"_121":58,"_122":-5,"_123":-5,"_124":125},"routes/_app.x.$handle.$name.branch.$branch.version.$version.diff",{"_11":12,"_13":14,"_15":16,"_17":-5,"_18":-5},"project",{"_43":44,"_32":45,"_38":46,"_47":-5,"_48":25,"_49":50,"_51":50,"_52":-5,"_53":-5,"_18":54,"_55":56,"_57":58,"_59":58,"_60":-5,"_61":62,"_63":64,"_65":-5,"_66":-5,"_67":-5,"_68":-5,"_69":70,"_71":70,"_72":73,"_74":73,"_75":73,"_76":70,"_77":70,"_78":79,"_80":81,"_82":83,"_84":25},"version",120,"changes",[19],"aiChatInfo","userId",{"_20":21,"_22":23,"_24":25,"_26":25,"_27":28,"_29":28},"file",{"_30":31,"_32":33,"_34":20,"_35":37,"_38":39,"_40":14,"_41":42,"_24":25},"previous",{"_30":31,"_32":33,"_34":20,"_35":36},"deleted",false,"deletedHere","path","frontend/index.html","latestPath","fileId","2f3fa440-3cdd-11f0-acd6-9e149126039e","name","index.html","fileType","content","\n\n \n \n \n Anthropic Chat with MCP\n \n \n \n \n \n \n

\n \n \n","\n\n \n \n \n Anthropic Chat with MCP\n \n \n \n \n \n \n

\n \n \n","createdAt",["D",1748731567571],"branchVersion","branchId","7e246fe2-3cdc-11f0-aa89-9e149126039e","id","7e24160a-3cdc-11f0-aa89-9e149126039e","Chat",["D",1748557815516],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","imageUrl","21f2e37e-8066-4730-9dc7-d27cf8d3c9f3","pinnedFileId","7471cb24-3cdd-11f0-8caa-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",{"_96":95,"_103":99},"org",{"_96":95,"_97":-5,"_98":99,"_18":54,"_100":101,"_102":25},"branch",{"_13":85,"_32":86,"_43":42,"_87":44,"_88":-5,"_89":-5,"_90":-5,"_91":-5,"_92":-5,"_93":45,"_94":95},"isOwned",1417,"main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","c15r","handle","displayName","avatar","https://img.clerk.com/eyJ0eXBlIjoicHJveHkiLCJzcmMiOiJodHRwczovL2ltYWdlcy5jbGVyay5kZXYvb2F1dGhfZ2l0aHViL2ltZ18yb2RJNlc1czZ1NlpZRmoxdGJ2eFVNNVhmeTYifQ","tier","pro","canRestrictVals","profileImageUrl","branchName","","adoptOrgId",{"_43":44,"_32":45,"_38":279,"_47":-5,"_48":25,"_49":50,"_51":50,"_52":-5,"_53":-5,"_18":54,"_55":56,"_57":58,"_59":58,"_60":-5,"_61":62,"_63":64,"_65":-5,"_66":-5,"_67":-5,"_68":-5,"_69":70,"_71":70,"_72":73,"_74":73,"_75":73,"_76":70,"_77":70,"_78":280,"_80":281,"_82":282,"_84":25},"tree",[172,174,183,185],"files",[172,173,174,175,176,177,178,179,180,181,182,183,184,185],"counts",{"_161":62,"_162":163,"_164":163,"_165":166,"_167":168},"contents",[127,128,129,130],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{"_56":126},"chat.parc.land",{"_43":155,"_32":156,"_30":157,"_134":-5,"_41":42,"_40":158,"_136":58,"_38":159,"_13":62,"_34":147,"_35":-5,"_24":25,"_140":-5,"_27":160},{"_43":149,"_32":150,"_30":151,"_134":-5,"_41":42,"_40":152,"_136":58,"_38":153,"_13":62,"_34":147,"_35":-5,"_24":25,"_140":-5,"_27":154},{"_43":142,"_32":143,"_30":144,"_134":-5,"_41":42,"_40":145,"_136":58,"_38":146,"_13":62,"_34":147,"_35":-5,"_24":25,"_140":-5,"_27":148},{"_43":131,"_32":132,"_30":133,"_134":-5,"_41":42,"_40":135,"_136":25,"_38":137,"_13":138,"_34":20,"_35":139,"_24":25,"_140":-5,"_27":141},"c8f57950-3e6f-11f0-a6fe-76b3cceeab13","README.md","2bc4d286-3cdd-11f0-9e50-9e149126039e","parentId",117,"latest",["D",1748731028218],20,"# Anthropic Streaming Chat with MCP\n\nA mobile-optimized single page chat application that uses the Anthropic Messages API with **real-time streaming** and MCP (Model Context Protocol) server support.\n\nSource: https://www.val.town/x/c15r/Chat \n\nLive server: https://c15r--7471cb243cdd11f08caa9e149126039e.web.val.run\n\nBundles Contextual MCP server by default: https://c15r--1564b217248f4a97a4d37bfe82cb8b19.web.val.run/mcp\n\n\n\n## Features\n\n- **🚀 Real-time streaming responses** - See Claude's responses appear word-by-word as they're generated\n- **⏹️ Stream control** - Stop streaming at any time with the stop button\n- Full-screen mobile-optimized chat interface\n- Direct client-side Anthropic API integration with server-side streaming proxy\n- **Model selection** - Choose between different Claude models (3.5 Sonnet, 3.5 Haiku, 3 Opus, etc.) without clearing chat history\n- Configurable MCP servers with localStorage persistence\n- **Clean footer layout** with text-based settings and clear chat links positioned alongside status text\n- **Enhanced MCP response handling** with collapsible sections for complex tool use and results\n- **Persistent chat history** - messages are saved to localStorage and restored on page load\n- **Structured display of MCP tool calls and results** to prevent truncation\n- **MCP server testing** - test button for each MCP server with visual status indicators (✅/❌)\n\n## Streaming Implementation\n\nThis app implements Anthropic's official streaming guide using:\n- Server-Sent Events (SSE) for real-time communication\n- Proper event parsing (`message_start`, `content_block_delta`, `message_stop`, etc.)\n- Content block reassembly for text, tool use, and thinking responses\n- Error handling and keep-alive support\n- Token usage tracking\n- Support for all delta types (text, JSON, thinking)\n\n## Project Structure\n\n```\n├── backend/\n│ ├── index.ts # Hono server with streaming endpoints\n│ └── anthropic.ts # Anthropic streaming client implementation\n├── frontend/\n│ ├── index.html # Main HTML template\n│ ├── index.tsx # React app entry point\n│ ├── components/\n│ │ ├── App.tsx # Main app component\n│ │ ├── StreamingChat.tsx # Real-time streaming chat interface\n│ │ ├── Chat.tsx # Legacy non-streaming chat (backup)\n│ │ ├── Settings.tsx # Settings flyout\n│ │ └── Message.tsx # Individual message component\n│ └── style.css # Custom styles with streaming animations\n├── shared/\n│ └── types.ts # Shared TypeScript types for streaming\n└── README.md\n```\n\n## Configuration\n\nThe app stores configuration and chat history in localStorage:\n- `anthropic_api_key`: Your Anthropic API key\n- `selected_model`: The chosen Claude model (defaults to claude-3-5-sonnet-20241022)\n- `mcp_servers`: Array of configured MCP servers\n- `chat_messages`: Complete chat history (persists between page loads)\n\n## API Endpoints\n\n- `POST /api/chat/stream` - Real-time streaming chat responses (SSE)\n- `POST /api/chat` - Non-streaming chat responses (fallback)\n- `POST /api/test-mcp` - Test MCP server connectivity and protocol compliance\n\n## Usage\n\n1. Open the app at the provided URL\n2. Click \"Settings\" in the footer to configure your Anthropic API key and select your preferred Claude model\n3. Add/remove/toggle MCP servers as needed\n4. Use the \"Test\" button next to each MCP server to verify connectivity (shows ✅ for success, ❌ for errors)\n5. Start chatting with Claude and watch responses stream in real-time!\n5. Use the stop button (⏹️) to interrupt streaming at any time\n6. Switch models anytime in settings without losing your chat history\n7. Your chat history and settings will be automatically saved and restored when you return\n\n## Default MCP Server\n\nThe app comes pre-configured with the Val Town MCP server:\n- **Name**: Val Town MCP\n- **URL**: `https://c15r--81c497c63c0a11f081e29e149126039e.web.val.run/mcp`\n- **Status**: Enabled by default (you'll need to add your authorization token)\n\n## Features in Detail\n\n- **Mobile-First Design**: Optimized for mobile devices with touch-friendly controls\n- **Real-time Streaming**: Watch Claude's responses appear word-by-word as they're generated\n- **Stream Control**: Stop streaming responses at any time with the stop button\n- **MCP Integration**: Support for multiple Model Context Protocol servers\n- **Enhanced MCP Display**: Collapsible sections for tool calls and results with proper JSON formatting\n- **Unobtrusive Footer Controls**: Settings (⚙️) and clear chat (🗑️) buttons positioned in the footer alongside the input\n- **Persistent Chat History**: All messages automatically saved to localStorage and restored on page load\n- **Persistent Settings**: All configuration stored in browser localStorage\n- **Auto-scroll**: Messages automatically scroll to bottom during streaming\n- **Auto-resize**: Input field grows with content\n- **Error Handling**: Clear error messages for API issues with stream recovery\n- **Loading States**: Visual feedback during API calls and streaming\n- **Structured Responses**: MCP tool use and results are displayed in organized, collapsible sections\n- **Clean Interface**: Maximized chat area with no header, footer contains all controls\n- **Streaming Animations**: Visual cursor and highlighting for active streaming responses","label",[132],"d0d818ac-3d49-11f0-afd9-76b3cceeab13","shared","d2bf992b-f210-4f83-bea3-aec8e3e2caaa",55,["D",1748604769414],"directory",[143],"2f3fab3e-3cdd-11f0-acd6-9e149126039e","frontend","43895adc-f88f-4b64-90b5-2b707f50c067",2,["D",1748558112658],[150],"7471d038-3cdd-11f0-8caa-9e149126039e","backend","b0b9068e-33c0-4fad-8bcf-5a3136836657",9,["D",1748558228747],[156],"pulls","branches",1,"forks","envVars",{"_169":62,"_171":62},"connections",{"_169":62,"_170":62},"count","unfilledCount","emptyCount",{"_43":155,"_32":156,"_30":157,"_134":-5,"_41":42,"_40":158,"_136":58,"_38":276,"_13":62,"_34":147,"_35":-5,"_24":25,"_140":-5,"_187":277,"_27":278},{"_43":267,"_32":268,"_30":56,"_134":157,"_41":42,"_40":269,"_136":25,"_38":270,"_13":271,"_34":272,"_35":273,"_24":25,"_140":-5,"_187":274,"_27":275},{"_43":149,"_32":150,"_30":151,"_134":-5,"_41":42,"_40":152,"_136":58,"_38":264,"_13":62,"_34":147,"_35":-5,"_24":25,"_140":-5,"_187":265,"_27":266},{"_43":259,"_32":233,"_30":226,"_134":151,"_41":42,"_40":260,"_136":58,"_38":261,"_13":62,"_34":147,"_35":-5,"_24":25,"_140":-5,"_187":262,"_27":263},{"_43":251,"_32":252,"_30":253,"_134":226,"_41":42,"_40":254,"_136":25,"_38":255,"_13":247,"_34":194,"_35":256,"_24":25,"_140":-5,"_187":257,"_27":258},{"_43":242,"_32":243,"_30":244,"_134":226,"_41":42,"_40":245,"_136":25,"_38":246,"_13":247,"_34":194,"_35":248,"_24":25,"_140":-5,"_187":249,"_27":250},{"_43":234,"_32":235,"_30":236,"_134":226,"_41":42,"_40":237,"_136":25,"_38":238,"_13":158,"_34":194,"_35":239,"_24":25,"_140":-5,"_187":240,"_27":241},{"_43":223,"_32":224,"_30":225,"_134":226,"_41":42,"_40":227,"_136":25,"_38":228,"_13":229,"_34":194,"_35":230,"_24":25,"_140":-5,"_187":231,"_27":232},{"_43":218,"_32":33,"_30":31,"_134":151,"_41":42,"_40":14,"_136":25,"_38":219,"_13":220,"_34":20,"_35":37,"_24":25,"_140":-5,"_187":221,"_27":222},{"_43":210,"_32":211,"_30":212,"_134":151,"_41":42,"_40":213,"_136":25,"_38":214,"_13":62,"_34":194,"_35":215,"_24":25,"_140":-5,"_187":216,"_27":217},{"_43":201,"_32":202,"_30":203,"_134":151,"_41":42,"_40":204,"_136":25,"_38":205,"_13":206,"_34":20,"_35":207,"_24":25,"_140":-5,"_187":208,"_27":209},{"_43":142,"_32":143,"_30":144,"_134":-5,"_41":42,"_40":145,"_136":58,"_38":198,"_13":62,"_34":147,"_35":-5,"_24":25,"_140":-5,"_187":199,"_27":200},{"_43":190,"_32":191,"_30":192,"_134":144,"_41":42,"_40":145,"_136":25,"_38":193,"_13":62,"_34":194,"_35":195,"_24":25,"_140":-5,"_187":196,"_27":197},{"_43":131,"_32":132,"_30":133,"_134":-5,"_41":42,"_40":135,"_136":25,"_38":186,"_13":138,"_34":20,"_35":139,"_24":25,"_140":-5,"_187":188,"_27":189},["D",1748731028218],"children",[],[132],"d0d80d3a-3d49-11f0-afd9-76b3cceeab13","types.ts","d0d80e16-3d49-11f0-afd9-76b3cceeab13",["D",1748604769414],"script","// Shared types for Anthropic streaming integration\n\nexport interface StreamEvent {\n event: string;\n data: string;\n}\n\nexport interface MessageStartEvent {\n type: \"message_start\";\n message: {\n id: string;\n type: \"message\";\n role: \"assistant\";\n content: any[];\n model: string;\n stop_reason: null;\n stop_sequence: null;\n usage: {\n input_tokens: number;\n output_tokens: number;\n };\n };\n}\n\nexport interface ContentBlockStartEvent {\n type: \"content_block_start\";\n index: number;\n content_block: {\n type: \"text\" | \"tool_use\";\n id?: string;\n name?: string;\n input?: any;\n text?: string;\n };\n}\n\nexport interface ContentBlockDeltaEvent {\n type: \"content_block_delta\";\n index: number;\n delta: {\n type: \"text_delta\" | \"input_json_delta\" | \"thinking_delta\" | \"signature_delta\";\n text?: string;\n partial_json?: string;\n thinking?: string;\n signature?: string;\n };\n}\n\nexport interface ContentBlockStopEvent {\n type: \"content_block_stop\";\n index: number;\n}\n\nexport interface MessageDeltaEvent {\n type: \"message_delta\";\n delta: {\n stop_reason?: string;\n stop_sequence?: string;\n };\n usage: {\n output_tokens: number;\n };\n}\n\nexport interface MessageStopEvent {\n type: \"message_stop\";\n}\n\nexport interface PingEvent {\n type: \"ping\";\n}\n\nexport interface ErrorEvent {\n type: \"error\";\n error: {\n type: string;\n message: string;\n };\n}\n\nexport type AnthropicStreamEvent = \n | MessageStartEvent\n | ContentBlockStartEvent\n | ContentBlockDeltaEvent\n | ContentBlockStopEvent\n | MessageDeltaEvent\n | MessageStopEvent\n | PingEvent\n | ErrorEvent;\n\nexport interface ChatMessage {\n role: \"user\" | \"assistant\" | \"system\";\n content: string;\n timestamp?: number;\n}\n\nexport interface StreamingChatRequest {\n messages: Array<{ role: string; content: string }>;\n model: string;\n max_tokens: number;\n anthropic_api_key: string;\n mcp_servers?: Array<{\n type: string;\n url: string;\n name: string;\n authorization_token?: string;\n }>;\n stream?: boolean;\n thinking?: {\n type: \"enabled\";\n budget_tokens: number;\n };\n tools?: Array<{\n name: string;\n description: string;\n input_schema: any;\n }>;\n}",[],[143,191],["D",1748604769414],[184],[143],"e09f2898-3e70-11f0-a2d5-76b3cceeab13","style.css","42e137de-3cdd-11f0-898f-9e149126039e",119,["D",1748731497418],24,"/* Custom styles for mobile optimization */\n\n.chat-container {\n xheight: 100svh;\n xposition: fixed;\n xtop: 0;\n display: flex;\n flex-direction: column;\n background: #f8fafc;\n width: 100svw;\n}\n\n.chat-messages {\n flex: 1;\n overflow-y: auto;\n padding: 1rem;\n scroll-behavior: smooth;\n -webkit-overflow-scrolling: touch;\n}\n\n.message {\n margin-bottom: 1rem;\n max-width: 85%;\n word-wrap: break-word;\n}\n\n.message > div > *:first-child {\n margin-top: 0;\n}\n\n.message > div > *:last-child {\n margin-bottom: 0;\n}\n\n.message.user {\n margin-left: auto;\n background: #3b82f6;\n color: white;\n padding: 0.75rem 1rem;\n border-radius: 1rem 1rem 0.25rem 1rem;\n}\n\n.message.assistant {\n background: white;\n border: 1px solid #e2e8f0;\n padding: 0.75rem 1rem;\n border-radius: 1rem 1rem 1rem 0.25rem;\n box-shadow: 0 1px 3px rgba(0, 0, 0, 0.1);\n}\n\n.message.system {\n background: #fef3c7;\n border: 1px solid #f59e0b;\n padding: 0.5rem 0.75rem;\n border-radius: 0.5rem;\n font-size: 0.875rem;\n margin: 0 auto;\n max-width: 90%;\n text-align: center;\n}\n\n.message pre {\n display: block;\n background: #f8fafc;\n border: 1px solid #e2e8f0;\n border-radius: 0.375rem;\n padding: 0.75rem;\n font-family: \"Monaco\", \"Menlo\", \"Ubuntu Mono\", monospace;\n font-size: 0.75rem;\n line-height: 1.4;\n overflow-x: auto;\n white-space: pre-wrap;\n word-break: break-word;\n color: #374151;\n margin: 0;\n}\n\n.chat-footer {\n position: absolute;\n bottom: 0;\n left: 0;\n right: 0;\n background: white;\n border-top: 1px solid #e2e8f0;\n box-shadow: 0 -2px 4px rgba(0, 0, 0, 0.05);\n}\n\n.chat-input-container {\n padding: 1rem;\n display: flex;\n gap: 0.5rem;\n align-items: flex-end;\n}\n\n.chat-input {\n flex: 1;\n min-height: 2.5rem;\n max-height: 6rem;\n padding: 0.75rem;\n border: 1px solid #d1d5db;\n border-radius: 0.5rem;\n resize: none;\n font-family: inherit;\n font-size: 1rem;\n outline: none;\n transition: border-color 0.2s;\n}\n\n.footer-controls {\n display: flex;\n gap: 0.25rem;\n align-items: flex-end;\n}\n\n.footer-button {\n background: none;\n border: none;\n color: #6b7280;\n cursor: pointer;\n padding: 0.5rem;\n border-radius: 0.5rem;\n transition: all 0.2s;\n font-size: 1rem;\n width: 2.5rem;\n height: 2.5rem;\n display: flex;\n align-items: center;\n justify-content: center;\n}\n\n.footer-button:hover {\n background: #f3f4f6;\n color: #374151;\n}\n\n.chat-status {\n padding: 0.5rem 1rem;\n background: #f8fafc;\n border-top: 1px solid #f1f5f9;\n display: flex;\n align-items: center;\n justify-content: space-between;\n}\n\n.status-text {\n font-size: 0.75rem;\n color: #6b7280;\n flex: 1;\n text-align: center;\n}\n\n.status-link-button {\n background: none;\n border: none;\n color: #3b82f6;\n cursor: pointer;\n font-size: 0.75rem;\n padding: 0.25rem 0.5rem;\n border-radius: 0.25rem;\n transition: all 0.2s;\n text-decoration: underline;\n}\n\n.status-link-button:hover {\n background: #f3f4f6;\n color: #2563eb;\n}\n\n.chat-input:focus {\n border-color: #3b82f6;\n box-shadow: 0 0 0 3px rgba(59, 130, 246, 0.1);\n}\n\n.send-button {\n background: #3b82f6;\n color: white;\n border: none;\n border-radius: 50%;\n width: 2.5rem;\n height: 2.5rem;\n display: flex;\n align-items: center;\n justify-content: center;\n cursor: pointer;\n transition: background-color 0.2s;\n flex-shrink: 0;\n font-size: 1rem;\n}\n\n.send-button:hover:not(:disabled) {\n background: #2563eb;\n}\n\n.send-button:disabled {\n background: #9ca3af;\n cursor: not-allowed;\n}\n\n.send-button.stop-button {\n background: #ef4444;\n}\n\n.send-button.stop-button:hover:not(:disabled) {\n background: #dc2626;\n}\n\n/* Streaming message styles */\n.message.streaming {\n background: white;\n border: 1px solid #e2e8f0;\n padding: 0.75rem 1rem;\n border-radius: 1rem 1rem 1rem 0.25rem;\n box-shadow: 0 1px 3px rgba(0, 0, 0, 0.1);\n border-left: 3px solid #3b82f6;\n}\n\n.streaming-cursor {\n display: inline-block;\n background: #3b82f6;\n color: #3b82f6;\n animation: streaming-blink 1s infinite;\n margin-left: 2px;\n}\n\n@keyframes streaming-blink {\n 0%, 50% {\n opacity: 1;\n }\n 51%, 100% {\n opacity: 0;\n }\n}\n\n.settings-overlay {\n position: fixed;\n top: 0;\n left: 0;\n right: 0;\n bottom: 0;\n background: rgba(0, 0, 0, 0.5);\n z-index: 50;\n display: flex;\n align-items: center;\n justify-content: center;\n padding: 1rem;\n}\n\n.settings-panel {\n background: white;\n border-radius: 1rem;\n padding: 1.5rem;\n width: 100%;\n max-width: 28rem;\n max-height: 80vh;\n overflow-y: auto;\n box-shadow: 0 20px 25px -5px rgba(0, 0, 0, 0.1);\n}\n\n.settings-header {\n display: flex;\n justify-content: space-between;\n align-items: center;\n margin-bottom: 1.5rem;\n padding-bottom: 1rem;\n border-bottom: 1px solid #e2e8f0;\n}\n\n.close-button {\n background: none;\n border: none;\n font-size: 1.5rem;\n cursor: pointer;\n color: #6b7280;\n padding: 0.25rem;\n border-radius: 0.25rem;\n}\n\n.close-button:hover {\n background: #f3f4f6;\n}\n\n.form-group {\n margin-bottom: 1.5rem;\n}\n\n.form-label {\n display: block;\n font-weight: 600;\n margin-bottom: 0.5rem;\n color: #374151;\n}\n\n.form-input {\n width: 100%;\n padding: 0.75rem;\n border: 1px solid #d1d5db;\n border-radius: 0.5rem;\n font-size: 1rem;\n transition: border-color 0.2s;\n}\n\n.form-input:focus {\n outline: none;\n border-color: #3b82f6;\n box-shadow: 0 0 0 3px rgba(59, 130, 246, 0.1);\n}\n\n.mcp-server {\n background: #f8fafc;\n border: 1px solid #e2e8f0;\n border-radius: 0.5rem;\n padding: 1rem;\n margin-bottom: 1rem;\n}\n\n.mcp-server-header {\n display: flex;\n justify-content: space-between;\n align-items: center;\n margin-bottom: 0.75rem;\n}\n\n.mcp-server-name {\n font-weight: 600;\n color: #374151;\n}\n\n.toggle-switch {\n position: relative;\n display: inline-block;\n width: 3rem;\n height: 1.5rem;\n}\n\n.toggle-switch input {\n opacity: 0;\n width: 0;\n height: 0;\n}\n\n.toggle-slider {\n position: absolute;\n cursor: pointer;\n top: 0;\n left: 0;\n right: 0;\n bottom: 0;\n background-color: #ccc;\n transition: 0.4s;\n border-radius: 1.5rem;\n}\n\n.toggle-slider:before {\n position: absolute;\n content: \"\";\n height: 1.125rem;\n width: 1.125rem;\n left: 0.1875rem;\n bottom: 0.1875rem;\n background-color: white;\n transition: 0.4s;\n border-radius: 50%;\n}\n\ninput:checked + .toggle-slider {\n background-color: #3b82f6;\n}\n\ninput:checked + .toggle-slider:before {\n transform: translateX(1.5rem);\n}\n\n.button {\n padding: 0.75rem 1.5rem;\n border: none;\n border-radius: 0.5rem;\n font-weight: 600;\n cursor: pointer;\n transition: all 0.2s;\n font-size: 0.875rem;\n}\n\n.button-primary {\n background: #3b82f6;\n color: white;\n}\n\n.button-primary:hover {\n background: #2563eb;\n}\n\n.button-secondary {\n background: #f3f4f6;\n color: #374151;\n border: 1px solid #d1d5db;\n}\n\n.button-secondary:hover {\n background: #e5e7eb;\n}\n\n.button-danger {\n background: #ef4444;\n color: white;\n}\n\n.button-danger:hover {\n background: #dc2626;\n}\n\n.loading-indicator {\n display: flex;\n align-items: center;\n gap: 0.5rem;\n color: #6b7280;\n font-size: 0.875rem;\n padding: 0.5rem 1rem;\n}\n\n.loading-dots {\n display: flex;\n gap: 0.25rem;\n}\n\n.loading-dot {\n width: 0.375rem;\n height: 0.375rem;\n background: #6b7280;\n border-radius: 50%;\n animation: loading-bounce 1.4s ease-in-out infinite both;\n}\n\n.loading-dot:nth-child(1) {\n animation-delay: -0.32s;\n}\n.loading-dot:nth-child(2) {\n animation-delay: -0.16s;\n}\n\n@keyframes loading-bounce {\n 0%, 80%, 100% {\n transform: scale(0);\n }\n 40% {\n transform: scale(1);\n }\n}\n\n/* Mobile optimizations */\n@media (max-width: 640px) {\n .chat-input-container {\n padding: 0.75rem;\n }\n\n .chat-status {\n padding: 0.375rem 0.75rem;\n }\n\n .status-text {\n font-size: 0.6875rem;\n }\n\n .status-link-button {\n font-size: 0.6875rem;\n padding: 0.125rem 0.25rem;\n }\n\n .settings-overlay {\n padding: 0.5rem;\n }\n\n .settings-panel {\n padding: 1rem;\n border-radius: 0.75rem;\n }\n\n .message {\n max-width: 90%;\n }\n}\n\n/* Prevent zoom on input focus on iOS */\n@media screen and (-webkit-min-device-pixel-ratio: 0) {\n .chat-input,\n .form-input {\n font-size: 16px;\n }\n}\n\n/* MCP Message Styling */\n.mcp-message {\n display: flex;\n flex-direction: column;\n gap: 0.75rem;\n}\n\n.mcp-structured-response {\n display: flex;\n flex-direction: column;\n gap: 0.5rem;\n}\n\n.mcp-text-content {\n margin-bottom: 0.5rem;\n}\n\n.mcp-regular-content {\n margin-bottom: 0.75rem;\n}\n\n.mcp-section {\n overflow: hidden;\n background: white;\n}\n\n.mcp-section-header {\n width: 100%;\n background: white;\n border: none;\n display: flex;\n align-items: center;\n gap: 0.5rem;\n cursor: pointer;\n transition: background-color 0.2s;\n text-align: left;\n color: #999;\n font-weight: normal;\n}\n\n.mcp-section-header:hover {}\n\n.mcp-section-icon {\n color: #6b7280;\n font-size: 0.875rem;\n width: 1rem;\n display: inline-block;\n display: none;\n}\n\n.mcp-section-title {\n flex: 1;\n font-size: 0.875rem;\n}\n\n.mcp-section-content {}\n\n.mcp-json {\n background: #f8fafc;\n border: 1px solid #e2e8f0;\n border-radius: 0.375rem;\n padding: 0.75rem;\n font-family: \"Monaco\", \"Menlo\", \"Ubuntu Mono\", monospace;\n font-size: 0.75rem;\n line-height: 1.4;\n overflow-x: auto;\n white-space: pre-wrap;\n word-break: break-word;\n color: #374151;\n margin: 0;\n}\n\n.mcp-tool-result.success .mcp-section-header {}\n\n.mcp-tool-result.success .mcp-section-header:hover {}\n\n.mcp-tool-result.error .mcp-section-header {\n color: red;\n}\n\n.mcp-tool-result.error .mcp-section-header:hover {}\n\n.mcp-tool-result.success {}\n\n.mcp-tool-result.error {}\n\n.test-button {\n background: #f3f4f6;\n border: 1px solid #d1d5db;\n border-radius: 0.375rem;\n padding: 0.375rem 0.75rem;\n font-size: 0.75rem;\n cursor: pointer;\n transition: all 0.2s;\n min-width: 2.5rem;\n display: flex;\n align-items: center;\n justify-content: center;\n}\n\n.test-button:hover:not(:disabled) {\n background: #e5e7eb;\n border-color: #9ca3af;\n}\n\n.test-button:disabled {\n cursor: not-allowed;\n opacity: 0.6;\n}",[],[150,202],"456d654a-3cdd-11f0-b47a-9e149126039e","index.tsx","456d6626-3cdd-11f0-b47a-9e149126039e",4,["D",1748558149866],"/** @jsxImportSource https://esm.sh/react@18.2.0 */\nimport React from \"https://esm.sh/react@18.2.0\";\nimport { createRoot } from \"https://esm.sh/react-dom@18.2.0/client\";\nimport App from \"./components/App.tsx\";\n\nconst root = createRoot(document.getElementById(\"root\")!);\nroot.render();",[],[150,211],"0a6fd6d6-3e71-11f0-8512-76b3cceeab13",["D",1748731567571],3,[],[150,33],"9f299802-3da4-11f0-bd83-76b3cceeab13","StreamingChat.tsx","10af5008-3d4a-11f0-8eb6-76b3cceeab13","35b7d323-5acc-4715-a23c-1ca451a40764",107,["D",1748643770258],14,"/** @jsxImportSource https://esm.sh/react@18.2.0 */\nimport React, { useCallback, useEffect, useRef, useState } from \"https://esm.sh/react@18.2.0\";\n\nimport { AnthropicStreamEvent } from \"../../shared/types.ts\";\nimport { AppConfig, Message } from \"./App.tsx\";\nimport MessageComponent from \"./Message.tsx\";\n\n/* ──────────────────────────────── Shared helpers ───────────────────────────── */\n\ntype Status = \"idle\" | \"thinking\" | \"streaming\";\n\ntype AssistantMsg = {\n role: \"assistant\";\n content: string; // JSON-stringified structured blocks (same as before)\n};\n\n/** Merge a delta into its parent block (unchanged logic) */\nfunction mergeDelta(block: any, delta: any) {\n if (!delta) return;\n switch (delta.type) {\n case \"text_delta\":\n block.text = (block.text ?? \"\") + (delta.text ?? \"\");\n break;\n case \"input_json_delta\":\n block._input_json_str = (block._input_json_str ?? \"\") + (delta.partial_json ?? \"\");\n break;\n default: {\n const { type: _ignored, ...rest } = delta;\n Object.assign(block, rest);\n }\n }\n}\n\n/** Build request body (handles MCP) */\nfunction buildBody(\n config: AppConfig,\n history: Message[],\n userText: string,\n): Record {\n const enabledMCP = config.mcpServers\n .filter((s) => s.enabled && s.url)\n .map((s) => ({\n type: \"url\",\n url: s.url,\n name: s.name,\n authorization_token: s.authorization_token,\n }));\n\n const apiMessages = history\n .filter((m) => m.role !== \"system\")\n .map((m) => ({ role: m.role, content: m.content }))\n .concat([{ role: \"user\", content: userText }]);\n\n return {\n model: config.selectedModel,\n max_tokens: 8_000,\n stream: true,\n messages: apiMessages,\n ...(enabledMCP.length && { mcp_servers: enabledMCP }),\n };\n}\n\n/** Build headers */\nfunction buildHeaders(apiKey: string, usingMCP: boolean): Record {\n const headers: Record = {\n \"x-api-key\": apiKey,\n \"anthropic-version\": \"2023-06-01\",\n \"content-type\": \"application/json\",\n \"anthropic-dangerous-direct-browser-access\": \"true\",\n };\n if (usingMCP) headers[\"anthropic-beta\"] = \"mcp-client-2025-04-04\";\n return headers;\n}\n\n/** Produce final assistant message identical to legacy implementation */\nfunction assembleMessage(blocks: Record): AssistantMsg {\n Object.values(blocks).forEach((b) => {\n if (b._input_json_str !== undefined) {\n try {\n b.input = JSON.parse(b._input_json_str);\n } catch {\n b.input_json_raw = b._input_json_str;\n }\n delete b._input_json_str;\n }\n });\n\n const structured = {\n role: \"assistant\",\n content: Object.keys(blocks)\n .map(Number)\n .sort((a, b) => a - b)\n .map((k) => {\n const { delta, _streaming, ...blk } = blocks[k];\n return blk;\n }),\n };\n\n return { role: \"assistant\", content: JSON.stringify(structured) };\n}\n\n/* ─────────────────────────────── useAnthropicStream ────────────────────────── */\n\nfunction useAnthropicStream(config: AppConfig) {\n const [status, setStatus] = useState(\"idle\");\n const [liveBlocks, setLiveBlocks] = useState(null); // structured preview\n const abortRef = useRef(null);\n\n /** Abort helper */\n const abort = useCallback(() => {\n abortRef.current?.abort();\n abortRef.current = null;\n setStatus(\"idle\");\n setLiveBlocks(null);\n }, []);\n\n /** Main send/stream function */\n const send = useCallback(\n async (history: Message[], userText: string): Promise => {\n if (!config.anthropicApiKey) throw new Error(\"API key missing\");\n if (status !== \"idle\") throw new Error(\"Stream already in progress\");\n\n setStatus(\"thinking\");\n\n const body = buildBody(config, history, userText);\n const headers = buildHeaders(\n config.anthropicApiKey,\n (body as any).mcp_servers?.length,\n );\n\n const ctrl = new AbortController();\n abortRef.current = ctrl;\n\n const resp = await fetch(\"https://api.anthropic.com/v1/messages\", {\n method: \"POST\",\n body: JSON.stringify(body),\n headers,\n signal: ctrl.signal,\n });\n\n if (!resp.ok) {\n const err = await resp.json().catch(() => ({}));\n throw new Error(\n err.error?.message\n ?? `Anthropic API error: ${resp.status} ${resp.statusText}`,\n );\n }\n if (!resp.body) throw new Error(\"Empty response body\");\n\n setStatus(\"streaming\");\n\n const reader = resp.body.getReader();\n const decoder = new TextDecoder();\n let buffer = \"\";\n const blocks: Record = {};\n\n while (true) {\n const { done, value } = await reader.read();\n if (done) break;\n\n buffer += decoder.decode(value, { stream: true });\n const lines = buffer.split(\"\\n\");\n buffer = lines.pop() ?? \"\";\n\n let current: { event?: string; data?: string } = {};\n\n for (const line of lines) {\n if (line.startsWith(\"event: \")) {\n current.event = line.slice(7);\n } else if (line.startsWith(\"data: \")) {\n current.data = line.slice(6);\n } else if (line === \"\" && current.event && current.data) {\n try {\n const ev = JSON.parse(current.data) as AnthropicStreamEvent;\n\n switch (ev.type) {\n case \"content_block_start\":\n blocks[ev.index] = structuredClone(ev.content_block);\n if (\n blocks[ev.index].type === \"text\"\n && blocks[ev.index].text === undefined\n ) {\n blocks[ev.index].text = \"\";\n }\n break;\n\n case \"content_block_delta\":\n if (blocks[ev.index]) {\n mergeDelta(blocks[ev.index], ev.delta);\n\n /* Prepare full preview structure */\n const ordered = Object.keys(blocks)\n .map(Number)\n .sort((a, b) => a - b);\n const full = ordered.map((k) => ({ ...blocks[k] }));\n\n if (full.length) {\n full[full.length - 1]._streaming = true;\n }\n setLiveBlocks(full);\n }\n break;\n\n case \"message_stop\":\n setStatus(\"idle\");\n setLiveBlocks(null);\n abortRef.current = null;\n reader.cancel();\n return assembleMessage(blocks);\n\n case \"error\":\n throw new Error(`Stream error: ${ev.error.message}`);\n }\n } catch (e) {\n console.warn(\"Failed to handle SSE frame\", e);\n }\n current = {};\n }\n }\n }\n\n // Should never reach here\n abortRef.current = null;\n setStatus(\"idle\");\n throw new Error(\"Stream ended unexpectedly\");\n },\n [config, status],\n );\n\n return { status, liveBlocks, send, abort };\n}\n\n/* ──────────────────────────── StreamingChat component ─────────────────────── */\n\ninterface StreamingChatProps {\n config: AppConfig;\n messages: Message[];\n onAddMessage: (m: Omit) => void;\n onClearMessages: () => void;\n onOpenSettings: () => void;\n}\n\nexport default function StreamingChat({\n config,\n messages,\n onAddMessage,\n onClearMessages,\n onOpenSettings,\n}: StreamingChatProps) {\n const [input, setInput] = useState(\"\");\n const textareaRef = useRef(null);\n const messagesEndRef = useRef(null);\n\n const { status, liveBlocks, send, abort } = useAnthropicStream(config);\n\n const thinking = status === \"thinking\";\n const streaming = status === \"streaming\";\n\n /* scroll to bottom on new content */\n useEffect(() => {\n messagesEndRef.current?.scrollIntoView({ behavior: \"smooth\" });\n }, [messages, liveBlocks]);\n\n /* auto-grow textarea */\n useEffect(() => {\n if (!textareaRef.current) return;\n textareaRef.current.style.height = \"auto\";\n textareaRef.current.style.height = `${textareaRef.current.scrollHeight}px`;\n }, [input]);\n\n /* ── helpers ──────────────────────────────────────────────── */\n\n /** Dispatch user input */\n const fireSend = async () => {\n if (!input.trim() || status !== \"idle\" || !config.anthropicApiKey) return;\n\n const userText = input.trim();\n setInput(\"\");\n onAddMessage({ role: \"user\", content: userText });\n\n try {\n const assistant = await send(\n [...messages, { role: \"user\", content: userText }],\n userText,\n );\n onAddMessage(assistant);\n } catch (err: any) {\n onAddMessage({\n role: \"system\",\n content: `Error: ${err.message ?? \"unknown\"}`,\n });\n }\n };\n\n /** Abort streaming and keep whatever we saw */\n const stopStreaming = () => {\n if (!streaming) return;\n\n const partial = liveBlocks\n ? liveBlocks.map((b) => {\n const { _streaming, ...rest } = b;\n return rest;\n })\n : [];\n\n abort();\n\n if (partial.length) {\n onAddMessage({\n role: \"assistant\",\n content: JSON.stringify({ role: \"assistant\", content: partial }),\n });\n } else {\n onAddMessage({ role: \"system\", content: \"Message cancelled by user\" });\n }\n };\n\n const handleKeyPress = (e: React.KeyboardEvent) => {\n if (e.key === \"Enter\" && !e.shiftKey) {\n e.preventDefault();\n streaming ? stopStreaming() : fireSend();\n }\n };\n\n const canSend = input.trim() && status === \"idle\" && config.anthropicApiKey;\n\n /* ── UI ─────────────────────────────────────────────────────── */\n return (\n <>\n

\n {!config.anthropicApiKey && (\n

\n Please configure your Anthropic API key in settings to start chatting\n

\n )}\n\n {messages.map((m, i) => )}\n\n {/* live streaming preview rendered with same renderer */}\n {streaming && liveBlocks && (\n \n )}\n\n {thinking && (\n

\n Claude is thinking\n

\n )}\n

\n\n {/* footer */}\n

\n setInput(e.target.value)}\n onKeyPress={handleKeyPress}\n placeholder={config.anthropicApiKey\n ? streaming\n ? \"Press Enter to stop streaming…\"\n : \"Type your message…\"\n : \"Configure API key in settings first\"}\n className=\"chat-input\"\n disabled={!config.anthropicApiKey || thinking}\n rows={1}\n />\n \n {streaming ? \"⏹\" : \"➤\"}\n \n

\n\n

\n \n Clear\n \n\n \n Claude Chat • {config.mcpServers.filter((s) => s.enabled).length}/\n {config.mcpServers.length} MCP servers enabled • {streaming ? \"Streaming…\" : \"Ready\"}\n \n\n \n Settings\n \n

\n \n );\n}",[],[150,233,224],"components","436610c6-3e31-11f0-9553-76b3cceeab13","Settings.tsx","7048e212-3cdd-11f0-8db8-9e149126039e",112,["D",1748704175345],"/** @jsxImportSource https://esm.sh/react@18.2.0 */\nimport React, { useState } from \"https://esm.sh/react@18.2.0\";\nimport { AppConfig, MCPServer } from \"./App.tsx\";\n\ninterface SettingsProps {\n config: AppConfig;\n onUpdateConfig: (config: Partial) => void;\n onClose: () => void;\n}\n\ninterface TestResult {\n [serverId: string]: {\n status: 'testing' | 'success' | 'error';\n message?: string;\n };\n}\n\nexport default function Settings({ config, onUpdateConfig, onClose }: SettingsProps) {\n const [apiKey, setApiKey] = useState(config.anthropicApiKey);\n const [mcpServers, setMcpServers] = useState(config.mcpServers);\n const [selectedModel, setSelectedModel] = useState(config.selectedModel);\n const [testResults, setTestResults] = useState({});\n\n const availableModels = [\n { id: \"claude-opus-4-20250514\", name: \"Claude Opus 4\" },\n { id: \"claude-sonnet-4-20250514\", name: \"Claude Sonnet 4\" },\n { id: \"claude-3-7-sonnet-20250219\", name: \"Claude 3.7 Sonnet\" },\n { id: \"claude-3-5-opus-20241022\", name: \"Claude 3.5 Opus\" },\n { id: \"claude-3-5-sonnet-20241022\", name: \"Claude 3.5 Sonnet\" },\n { id: \"claude-3-5-haiku-20241022\", name: \"Claude 3.5 Haiku\" },\n { id: \"claude-3-opus-20240229\", name: \"Claude 3 Opus\" },\n { id: \"claude-3-sonnet-20240229\", name: \"Claude 3 Sonnet\" },\n { id: \"claude-3-haiku-20240307\", name: \"Claude 3 Haiku\" },\n ];\n\n const handleSave = () => {\n onUpdateConfig({\n anthropicApiKey: apiKey,\n mcpServers: mcpServers,\n selectedModel: selectedModel,\n });\n onClose();\n };\n\n const addMcpServer = () => {\n const newServer: MCPServer = {\n id: `mcp-${Date.now()}`,\n name: \"New MCP Server\",\n url: \"\",\n authorization_token: \"\",\n enabled: true,\n };\n setMcpServers([...mcpServers, newServer]);\n };\n\n const updateMcpServer = (id: string, updates: Partial) => {\n setMcpServers(servers => servers.map(server => server.id === id ? { ...server, ...updates } : server));\n };\n\n const removeMcpServer = (id: string) => {\n setMcpServers(servers => servers.filter(server => server.id !== id));\n };\n\n const toggleMcpServer = (id: string) => {\n updateMcpServer(id, { enabled: !mcpServers.find(s => s.id === id)?.enabled });\n };\n\n const testMcpServer = async (server: MCPServer) => {\n if (!server.url) {\n setTestResults(prev => ({\n ...prev,\n [server.id]: { status: 'error', message: 'URL is required' }\n }));\n return;\n }\n\n setTestResults(prev => ({\n ...prev,\n [server.id]: { status: 'testing' }\n }));\n\n try {\n const response = await fetch('/api/test-mcp', {\n method: 'POST',\n headers: {\n 'Content-Type': 'application/json',\n },\n body: JSON.stringify({\n url: server.url,\n authorization_token: server.authorization_token,\n }),\n });\n\n const result = await response.json();\n \n setTestResults(prev => ({\n ...prev,\n [server.id]: {\n status: result.success ? 'success' : 'error',\n message: result.success ? result.message : result.error\n }\n }));\n } catch (error: any) {\n setTestResults(prev => ({\n ...prev,\n [server.id]: {\n status: 'error',\n message: error.message || 'Failed to test server'\n }\n }));\n }\n };\n\n const getTestButtonContent = (server: MCPServer) => {\n const result = testResults[server.id];\n if (!result) return \"Test\";\n \n switch (result.status) {\n case 'testing':\n return \"⏳\";\n case 'success':\n return \"✅\";\n case 'error':\n return \"❌\";\n default:\n return \"Test\";\n }\n };\n\n const getTestButtonTitle = (server: MCPServer) => {\n const result = testResults[server.id];\n if (!result) return \"Test MCP server connection\";\n \n switch (result.status) {\n case 'testing':\n return \"Testing connection...\";\n case 'success':\n return `Success: ${result.message}`;\n case 'error':\n return `Error: ${result.message}`;\n default:\n return \"Test MCP server connection\";\n }\n };\n\n return (\n

e.target === e.currentTarget && onClose()}>\n

Settings

\n \n

\n\n {/* API Key Section */}\n

\n Anthropic API Key\n setApiKey(e.target.value)}\n placeholder=\"sk-ant-...\"\n className=\"form-input\"\n />\n

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

\n\n {/* Model Selection */}\n

\n Model\n setSelectedModel(e.target.value)}\n className=\"form-input\"\n >\n {availableModels.map((model) => (\n \n ))}\n \n

\n Choose the Claude model to use for conversations. Changes apply to new messages without clearing chat\n history.\n

\n\n {/* MCP Servers Section */}\n

\n MCP Servers\n \n

\n\n {mcpServers.map((server) => (\n

\n updateMcpServer(server.id, { name: e.target.value })}\n className=\"mcp-server-name bg-transparent border-none outline-none flex-1\"\n placeholder=\"Server name\"\n />\n

\n testMcpServer(server)}\n disabled={testResults[server.id]?.status === 'testing'}\n className=\"test-button\"\n title={getTestButtonTitle(server)}\n >\n {getTestButtonContent(server)}\n \n \n toggleMcpServer(server.id)}\n />\n \n \n removeMcpServer(server.id)}\n className=\"text-red-600 hover:text-red-800 p-1\"\n title=\"Remove server\"\n >\n 🗑️\n \n

\n\n

\n updateMcpServer(server.id, { url: e.target.value })}\n placeholder=\"https://example.com/mcp\"\n className=\"form-input text-sm\"\n />\n updateMcpServer(server.id, { authorization_token: e.target.value })}\n placeholder=\"Authorization token\"\n className=\"form-input text-sm\"\n />\n {testResults[server.id]?.message && (\n

\n {testResults[server.id].message}\n

\n )}\n

\n ))}\n\n {mcpServers.length === 0 && (\n

\n No MCP servers configured. Add one to get started.\n

\n )}\n

\n\n {/* Action Buttons */}\n

\n \n \n

\n );\n}",[],[150,233,235],"67f418d8-3da6-11f0-98a4-76b3cceeab13","Message.tsx","629c8178-3cdd-11f0-8042-9e149126039e",108,["D",1748644536630],11,"/** @jsxImportSource https://esm.sh/react@18.2.0 */\nimport { marked } from \"https://cdn.jsdelivr.net/npm/marked/lib/marked.esm.js\";\nimport React, { useState } from \"https://esm.sh/react@18.2.0\";\nimport { Message } from \"./App.tsx\";\n\ninterface MessageProps {\n message: Message;\n}\n\n/* ──────────────────────────── Streaming-block helper types ────────────────── */\ninterface AnthropicBlock {\n type: string;\n text?: string;\n language?: string; // for code blocks\n _streaming?: boolean; // present on the *current* block being streamed\n /* keep-all for future keys */\n [key: string]: any;\n}\n\n/* ───────────────────────────────────────────────────────────────────────────── */\n\nexport default function MessageComponent({ message }: MessageProps) {\n const [expandedSections, setExpandedSections] = useState>(\n new Set(),\n );\n\n const toggleSection = (sectionId: string) => {\n const newExpanded = new Set(expandedSections);\n newExpanded.has(sectionId)\n ? newExpanded.delete(sectionId)\n : newExpanded.add(sectionId);\n setExpandedSections(newExpanded);\n };\n\n /* ═══════ Utilities shared by several renderers ════════════════════════════ */\n\n const renderCollapsibleSection = (\n title: string,\n content: any,\n sectionId: string,\n ) => {\n const affordance = content?.result?.output?.html;\n const isExpanded = affordance || expandedSections.has(sectionId);\n\n return (\n

\n toggleSection(sectionId)}\n >\n {isExpanded ? \"▼\" : \"▶\"}\n {title}\n \n\n {isExpanded && (\n

\n {affordance\n ?

\n : (\n

\n                {typeof content === \"string\"\n                  ? content\n                  : JSON.stringify(content, null, 2)}\n

\n )}\n

\n );\n };\n\n const formatRegularContent = (content: string) =>

;\n\n /* ═══════ 1. Renderer for *streaming* Anthropic blocks (live preview) ══════ */\n\n const renderAnthropicBlocks = (blocks: AnthropicBlock[]) => (\n

\n {blocks.map((blk, idx) => {\n switch (blk.type) {\n case \"text\":\n return (\n

\n {formatRegularContent(blk.text ?? \"\")}\n {blk._streaming && ▊}\n

\n );\n\n case \"code\":\n // Re-wrap code in markdown fences so existing MD pipeline highlights it\n return (\n

\n {formatRegularContent(\n `\\`\\`\\`${blk.language ?? \"\"}\\n${blk.text ?? \"\"}\\n\\`\\`\\``,\n )}\n

\n );\n\n /* Unknown or future block types */\n default:\n return (\n

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

\n );\n }\n })}\n

\n );\n\n /* ═══════ 2. Existing MCP-aware string renderer (unchanged) ═══════════════ */\n\n const renderStructuredMCPResponse = (response: any) => {\n const sections: JSX.Element[] = [];\n\n response.content.forEach((item: any, index: number) => {\n const sectionId = `structured-${index}`;\n\n switch (item.type) {\n case \"text\":\n sections.push(\n

\n {formatRegularContent(item.text || \"\")}\n

,\n );\n break;\n\n case \"mcp_tool_use\":\n sections.push(\n renderCollapsibleSection(\n `${item.name} (${item.server_name})`,\n { id: item.id, input: item.input },\n sectionId,\n ),\n );\n break;\n\n case \"mcp_tool_result\":\n const isError = item.is_error;\n const resultContent = item.content?.[0]?.text;\n let parsedResult = resultContent;\n\n try {\n if (resultContent) parsedResult = JSON.parse(resultContent);\n } catch {\n /* leave as string */\n }\n\n sections.push(\n \n {renderCollapsibleSection(\n `${isError ? \"❌\" : \"\"} Result ${isError ? \"(Error)\" : \"(Success)\"}`,\n { tool_use_id: item.tool_use_id, result: parsedResult },\n sectionId,\n )}\n

,\n );\n break;\n\n default:\n sections.push(\n renderCollapsibleSection(\n `📄 ${item.type || \"Unknown Content\"}`,\n item,\n sectionId,\n ),\n );\n }\n });\n\n return

{sections}

;\n };\n\n const detectAndFormatMCPContent = (content: string) => {\n // Try full structured parse first\n try {\n const parsed = JSON.parse(content);\n if (parsed.content && Array.isArray(parsed.content)) {\n return renderStructuredMCPResponse(parsed);\n }\n } catch {\n /* fall through */\n }\n\n // Fallback: heuristic detection line-by-line\n const lines = content.split(\"\\n\");\n const sections: JSX.Element[] = [];\n let currentSection = \"\";\n let counter = 0;\n\n for (const line of lines) {\n const emitPlain = () => {\n if (currentSection.trim()) {\n sections.push(\n

\n {formatRegularContent(currentSection.trim())}\n

,\n );\n currentSection = \"\";\n }\n };\n\n // Tool calls\n if (line.includes(\"tool_use\") || line.includes(\"function_call\")) {\n emitPlain();\n try {\n sections.push(\n renderCollapsibleSection(\n \"🔧 Tool Call\",\n JSON.parse(line),\n `tool-${counter++}`,\n ),\n );\n continue;\n } catch {}\n }\n\n // Tool results\n if (line.includes(\"tool_result\") || line.includes(\"function_result\")) {\n emitPlain();\n try {\n sections.push(\n renderCollapsibleSection(\n \"📊 Tool Result\",\n JSON.parse(line),\n `result-${counter++}`,\n ),\n );\n continue;\n } catch {}\n }\n\n // Possible MCP JSON blobs\n if (line.trim().startsWith(\"{\") && line.includes(\"mcp\")) {\n emitPlain();\n try {\n sections.push(\n renderCollapsibleSection(\n \"🔗 MCP Response\",\n JSON.parse(line),\n `mcp-${counter++}`,\n ),\n );\n continue;\n } catch {}\n }\n\n // Regular text\n currentSection += line + \"\\n\";\n }\n\n // Flush remaining plain text\n if (currentSection.trim()) {\n sections.push(\n

\n {formatRegularContent(currentSection.trim())}\n

,\n );\n }\n\n return sections.length ?

{sections}

: (\n formatRegularContent(content)\n );\n };\n\n /* ═══════ Decide renderer based on runtime type ═══════════════════════════ */\n\n const renderContent = () => {\n const content = message.content as unknown;\n\n // 1. Live preview (array of blocks)\n if (Array.isArray(content)) {\n return renderAnthropicBlocks(content as AnthropicBlock[]);\n }\n\n // 2. Regular / final path (string)\n if (typeof content === \"string\") {\n return detectAndFormatMCPContent(content);\n }\n\n // 3. Defensive fallback\n return (\n

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

\n );\n };\n\n /* ═══════ Render wrapper ══════════════════════════════════════════════════ */\n\n return

{renderContent()}

;\n}",[],[150,233,243],"09074a50-3e70-11f0-bdcf-76b3cceeab13","App.tsx","4d426996-3cdd-11f0-832c-9e149126039e",118,["D",1748731135711],"/** @jsxImportSource https://esm.sh/react@18.2.0 */\nimport React, { useEffect, useState } from \"https://esm.sh/react@18.2.0\";\nimport Settings from \"./Settings.tsx\";\nimport StreamingChat from \"./StreamingChat.tsx\";\n\nexport interface MCPServer {\n id: string;\n name: string;\n url: string;\n authorization_token: string;\n enabled: boolean;\n}\n\nexport interface Message {\n role: \"user\" | \"assistant\" | \"system\";\n content: string;\n timestamp: number;\n}\n\nexport interface AppConfig {\n anthropicApiKey: string;\n mcpServers: MCPServer[];\n selectedModel: string;\n}\n\nconst DEFAULT_MCP_SERVERS: MCPServer[] = [\n {\n id: \"contextual-mcp\",\n name: \"Contentual\",\n url: \"https://c15r--1564b217248f4a97a4d37bfe82cb8b19.web.val.run/mcp\",\n authorization_token: \"toqmU9-sacmeg-teznab\",\n enabled: true,\n },\n];\n\nexport default function App() {\n const [config, setConfig] = useState({\n anthropicApiKey: \"\",\n mcpServers: DEFAULT_MCP_SERVERS,\n selectedModel: \"claude-3-5-sonnet-20241022\",\n });\n const [showSettings, setShowSettings] = useState(false);\n const [messages, setMessages] = useState([]);\n\n // Load config from localStorage on mount\n useEffect(() => {\n const savedApiKey = localStorage.getItem(\"anthropic_api_key\");\n const savedMcpServers = localStorage.getItem(\"mcp_servers\");\n const savedMessages = localStorage.getItem(\"chat_messages\");\n const savedModel = localStorage.getItem(\"selected_model\");\n\n setConfig({\n anthropicApiKey: savedApiKey || \"\",\n mcpServers: savedMcpServers ? JSON.parse(savedMcpServers) : DEFAULT_MCP_SERVERS,\n selectedModel: savedModel || \"claude-3-5-sonnet-20241022\",\n });\n\n // Load saved messages\n if (savedMessages) {\n try {\n const parsedMessages = JSON.parse(savedMessages);\n setMessages(parsedMessages);\n } catch (error) {\n console.error(\"Failed to load saved messages:\", error);\n }\n }\n\n // Show settings if no API key is configured\n if (!savedApiKey) {\n setShowSettings(true);\n }\n }, []);\n\n // Save config to localStorage when it changes\n useEffect(() => {\n if (config.anthropicApiKey) {\n localStorage.setItem(\"anthropic_api_key\", config.anthropicApiKey);\n }\n localStorage.setItem(\"mcp_servers\", JSON.stringify(config.mcpServers));\n localStorage.setItem(\"selected_model\", config.selectedModel);\n }, [config]);\n\n // Save messages to localStorage when they change\n useEffect(() => {\n localStorage.setItem(\"chat_messages\", JSON.stringify(messages));\n }, [messages]);\n\n const updateConfig = (newConfig: Partial) => {\n setConfig(prev => ({ ...prev, ...newConfig }));\n };\n\n const addMessage = (message: Omit) => {\n setMessages(prev => [...prev, { ...message, timestamp: Date.now() }]);\n };\n\n const updateLastMessage = (content: string) => {\n setMessages(prev => {\n if (prev.length === 0) return prev;\n const updated = [...prev];\n updated[updated.length - 1] = { ...updated[updated.length - 1], content };\n return updated;\n });\n };\n\n const clearMessages = () => {\n setMessages([]);\n };\n\n return (\n

\n setShowSettings(true)}\n />\n {showSettings && (\n setShowSettings(false)}\n />\n )}\n

\n );\n}",[],[150,233,252],"4d427e7c-3cdd-11f0-832c-9e149126039e",5,["D",1748558163004],[176,177,178,179],[150,233],["D",1748558112658],[175,180,181,182],[150],"2c699488-3e31-11f0-adcc-76b3cceeab13","index.ts",109,["D",1748704136777],8,"http","import { Hono } from \"https://esm.sh/hono@3.11.7\";\nimport { readFile, serveFile } from \"https://esm.town/v/std/utils@85-main/index.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// Test MCP server endpoint\napp.post(\"/api/test-mcp\", async c => {\n try {\n const { url, authorization_token } = await c.req.json();\n \n if (!url) {\n return c.json({ success: false, error: \"URL is required\" }, 400);\n }\n\n // Test the MCP server by making a simple request\n const headers: Record = {\n \"Content-Type\": \"application/json\",\n };\n \n if (authorization_token) {\n headers[\"Authorization\"] = `Bearer ${authorization_token}`;\n }\n\n // Try to make a basic request to the MCP server\n // Most MCP servers should respond to a simple GET or POST request\n const response = await fetch(url, {\n method: \"POST\",\n headers,\n body: JSON.stringify({\n jsonrpc: \"2.0\",\n method: \"initialize\",\n params: {\n protocolVersion: \"2024-11-05\",\n capabilities: {},\n clientInfo: {\n name: \"chat-test\",\n version: \"1.0.0\"\n }\n },\n id: 1\n }),\n signal: AbortSignal.timeout(10000) // 10 second timeout\n });\n\n if (response.ok) {\n const data = await response.json();\n // Check if it's a valid MCP response\n if (data.jsonrpc === \"2.0\" && (data.result || data.error)) {\n return c.json({ \n success: true, \n message: \"MCP server responded successfully\",\n status: response.status\n });\n } else {\n return c.json({ \n success: false, \n error: \"Server responded but not with valid MCP protocol\",\n status: response.status\n });\n }\n } else {\n return c.json({ \n success: false, \n error: `Server returned ${response.status}: ${response.statusText}`,\n status: response.status\n });\n }\n } catch (error: any) {\n if (error.name === 'TimeoutError') {\n return c.json({ \n success: false, \n error: \"Request timed out - server may be unreachable\" \n }, 408);\n }\n \n return c.json({ \n success: false, \n error: error.message || \"Unknown error occurred\" \n }, 500);\n }\n});\n\n// Serve static 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// Serve the main app\napp.get(\"/\", async c => {\n const html = await readFile(\"/frontend/index.html\", import.meta.url);\n return c.html(html);\n});\n\nexport default app.fetch;",[],[156,268],["D",1748558228747],[173],[156],["D",1748557815516],{"_96":95,"_103":99},{"_96":95,"_97":-5,"_98":99,"_18":54,"_100":101,"_102":25},{"_13":85,"_32":86,"_43":42,"_87":44,"_88":-5,"_89":-5,"_90":-5,"_91":-5,"_92":-5,"_93":45,"_94":95},"ctx",{"_78":-5,"_123":316,"_317":318,"_319":320,"_321":25,"_322":25,"_323":25,"_324":58,"_325":-5,"_326":-7,"_327":-7,"_328":62,"_329":25,"_330":25,"_331":-5,"_332":25,"_333":25,"_334":25,"_335":-5},"ENV",{"_287":288,"_289":290,"_291":86,"_292":293,"_294":295,"_296":297,"_298":299,"_300":301,"_302":303,"_304":305,"_306":307,"_308":309,"_310":311,"_312":313,"_314":315},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","RENDER_GIT_COMMIT","5015b8df46402d8bba4f485ecc37aec202b0e06b","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 · v120