Update app.py

app.py

@@ -3,6 +3,7 @@ import json
 import requests
 from fastapi import FastAPI, Request
 from fastapi.responses import Response
+from fastapi.middleware.cors import CORSMiddleware
 from mcp.server.lowlevel import Server, NotificationOptions
 from mcp.server.sse import SseServerTransport
 from mcp import types as mcp_types
@@ -18,6 +19,15 @@ logger = logging.getLogger(__name__)
 
 app = FastAPI()
 
+# Add CORS middleware to allow Deep Agent to connect
+app.add_middleware(
+    CORSMiddleware,
+    allow_origins=["*"],  # Adjust for production
+    allow_credentials=True,
+    allow_methods=["*"],
+    allow_headers=["*"],
+)
+
 # Load environment variables
 AIRTABLE_API_TOKEN = os.getenv("AIRTABLE_API_TOKEN")
 AIRTABLE_BASE_ID = os.getenv("AIRTABLE_BASE_ID")
@@ -140,8 +150,27 @@ async def handle_post_message(request: Request):
     logger.debug("Handling POST message request")
     body = await request.body()
     logger.debug(f"Received POST message body: {body}")
-    await transport.handle_post_message(request.scope, request.receive, request._send)
-    logger.debug("POST message handled successfully")
+    try:
+        message = json.loads(body.decode())
+        if message.get("method") == "tools/list":
+            logger.debug("Handling tools/list request manually")
+            # Create a ListToolsResult response
+            response = {
+                "jsonrpc": "2.0",
+                "id": message.get("id"),
+                "result": {
+                    "tools": [tool.model_dump(by_alias=True, exclude_none=True) for tool in tools]
+                }
+            }
+            # Send the response back through the SSE stream
+            # Since we don't have direct access to transport's send method, log for now
+            logger.debug(f"Manual tools/list response: {response}")
+            # We need to find a way to send this response back through the SSE stream
+            # For now, rely on Server to handle it
+        await transport.handle_post_message(request.scope, request.receive, request._send)
+        logger.debug("POST message handled successfully")
+    except Exception as e:
+        logger.error(f"Error handling POST message: {str(e)}")
     return Response(status_code=202)
 
 # Health check endpoint