mcp int v1

app.py

@@ -336,18 +336,62 @@ class MCPServer:
     
     def start(self):
         """Start the MCP server in a separate process"""
+        if self.is_running():
+            logger.info("MCP server is already running")
+            return True
+            
         try:
             import subprocess
+            import sys
+            
+            # Use the same Python executable that's running this script
+            python_exec = sys.executable
+            
+            logger.info(f"Starting MCP server with: {python_exec} mcp_server.py")
+            
             self.process = subprocess.Popen(
-                ["python", "mcp_server.py"],
+                [python_exec, "mcp_server.py"],
                 stdout=subprocess.PIPE,
-                stderr=subprocess.PIPE
+                stderr=subprocess.PIPE,
+                text=True,
+                bufsize=1,
+                universal_newlines=True
             )
-            # Give it a moment to start
-            time.sleep(2)
-            return True
+            
+            # Log the output in real-time
+            def log_output(pipe, logger_func):
+                for line in iter(pipe.readline, ''):
+                    if line:
+                        logger_func(line.strip())
+            
+            # Start logging threads
+            import threading
+            threading.Thread(
+                target=log_output,
+                args=(self.process.stdout, logger.info),
+                daemon=True
+            ).start()
+            
+            threading.Thread(
+                target=log_output,
+                args=(self.process.stderr, logger.error),
+                daemon=True
+            ).start()
+            
+            # Wait for server to be ready
+            import time
+            max_attempts = 10
+            for _ in range(max_attempts):
+                if self.is_running():
+                    logger.info("MCP server started successfully")
+                    return True
+                time.sleep(0.5)
+                
+            logger.error("MCP server failed to start within the expected time")
+            return False
+            
         except Exception as e:
-            logger.error(f"Failed to start MCP server: {str(e)}")
+            logger.error(f"Failed to start MCP server: {str(e)}", exc_info=True)
             return False
     
     def stop(self):
@@ -359,9 +403,11 @@ class MCPServer:
     def is_running(self) -> bool:
         """Check if MCP server is running"""
         try:
+            import requests
             response = requests.get(f"{self.base_url}/health", timeout=2)
             return response.status_code == 200
-        except:
+        except Exception as e:
+            logger.debug(f"MCP server health check failed: {str(e)}")
             return False
 
 # Initialize MCP server

mcp_server.py

@@ -1,16 +1,27 @@
 import os
 import json
+import logging
 from fastapi import FastAPI, HTTPException
 from fastapi.middleware.cors import CORSMiddleware
 from pydantic import BaseModel
 from typing import Dict, List, Optional
-import logging
 
 # Set up logging
-logging.basicConfig(level=logging.INFO)
+logging.basicConfig(
+    level=logging.INFO,
+    format='%(asctime)s - %(name)s - %(levelname)s - %(message)s',
+    handlers=[
+        logging.StreamHandler(),
+        logging.FileHandler('mcp_server.log')
+    ]
+)
 logger = logging.getLogger(__name__)
 
-app = FastAPI(title="Content Creation Agent MCP Server")
+app = FastAPI(
+    title="Content Creation Agent MCP Server",
+    description="MCP Server for Content Creation Agent",
+    version="1.0.0"
+)
 
 # Enable CORS for all origins
 app.add_middleware(
@@ -88,4 +99,24 @@ async def health_check():
 
 if __name__ == "__main__":
     import uvicorn
-    uvicorn.run(app, host="0.0.0.0", port=8000)
+    import sys
+    
+    port = 8000
+    host = "0.0.0.0"
+    
+    logger.info(f"Starting MCP server on {host}:{port}")
+    logger.info(f"Python version: {sys.version}")
+    logger.info(f"FastAPI version: {FastAPI.__version__ if hasattr(FastAPI, '__version__') else 'unknown'}")
+    
+    try:
+        uvicorn.run(
+            app,
+            host=host,
+            port=port,
+            log_level="info",
+            access_log=True,
+            reload=False
+        )
+    except Exception as e:
+        logger.exception("Failed to start MCP server")
+        sys.exit(1)

requirements-mcp.txt

@@ -0,0 +1,5 @@
+fastapi>=0.68.0,<0.69.0
+uvicorn[standard]>=0.15.0,<0.16.0
+pydantic>=1.8.0,<2.0.0
+python-multipart>=0.0.5,<0.1.0
+requests>=2.26.0,<3.0.0