From 732edba35c3d574221693410ddf62142bb190f54 Mon Sep 17 00:00:00 2001
From: saidsurucu <saidsrc@gmail.com>
Date: Wed, 2 Jul 2025 03:31:55 +0300
Subject: [PATCH] Add /mcp handler to forward to MCP app
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

- Create explicit FastAPI handlers for /mcp GET/POST
- Forward requests to mounted /mcp/ app via ASGI
- This should fix Claude's 405 Method Not Allowed errors

🤖 Generated with [Claude Code](https://claude.ai/code)

Co-Authored-By: Claude <noreply@anthropic.com>
---
 asgi_app.py | 37 +++++++++++++++++++++++++++++++++++--
 1 file changed, 35 insertions(+), 2 deletions(-)

diff --git a/asgi_app.py b/asgi_app.py
index 9f67566..e99af90 100644
--- a/asgi_app.py
+++ b/asgi_app.py
@@ -81,10 +81,43 @@ async def custom_401_handler(request: Request, exc: HTTPException):
     return response
 
 # Mount MCP app as sub-application
-# Order matters: mount more specific paths first
-app.mount("/mcp", mcp_app)  # Mount without trailing slash for Claude compatibility
 app.mount("/mcp/", mcp_app)
 
+# Add simple handler for /mcp POST requests
+@app.post("/mcp")
+@app.get("/mcp") 
+async def mcp_handler(request: Request):
+    """Handle /mcp requests by forwarding to MCP app"""
+    # Modify scope to look like /mcp/ request
+    scope = request.scope.copy()
+    scope["path"] = "/mcp/"
+    scope["path_info"] = "/mcp/"
+    
+    # Forward to mcp_app
+    async def receive():
+        return await request.receive()
+    
+    # Capture response
+    response_data = {"body": b"", "status_code": 200, "headers": []}
+    
+    async def send(message):
+        if message["type"] == "http.response.start":
+            response_data["status_code"] = message["status"]
+            response_data["headers"] = message["headers"]
+        elif message["type"] == "http.response.body":
+            response_data["body"] += message.get("body", b"")
+    
+    # Call mcp_app
+    await mcp_app(scope, receive, send)
+    
+    # Return response
+    from starlette.responses import Response
+    return Response(
+        content=response_data["body"],
+        status_code=response_data["status_code"],
+        headers=dict(response_data["headers"])
+    )
+
 # FastAPI health check endpoint
 @app.get("/health")
 async def health_check():