Add SSE support for cloud deployment

mcp.json

@@ -1,25 +1,10 @@
 {
-  "$schema": "https://json.schemastore.org/mcp.json",
-  "$comment": "Echo Universal Host - MCP Server Configuration",
+  "$schema": "https://json-schema.org/draft/2020-12/schema",
+  "$comment": "MCP Server Configuration for Echo Client (Hugging Face Deployment)",
   "mcpServers": {
     "agentbell-voice": {
-      "command": "python",
-      "args": [
-        "services/mcp_server/server.py"
-      ],
-      "env": {
-        "PYTHONUNBUFFERED": "1",
-        "PYTHONPATH": "."
-      },
-      "_description": "AgentBell Voice MCP Server - Provides voice notification tools"
-    },
-    "memory": {
-      "command": "npx",
-      "args": [
-        "-y",
-        "@modelcontextprotocol/server-memory"
-      ],
-      "_description": "Simple in-memory key-value store for testing MCP connections"
+      "url": "https://mcp-1st-birthday-agentbell-mcp-server.hf.space/sse",
+      "_description": "AgentBell Voice Companion (Cloud-hosted SSE)"
     }
   }
 }

src/core/mcp_client.py

@@ -7,6 +7,7 @@ from contextlib import AsyncExitStack
 
 from mcp import ClientSession, StdioServerParameters
 from mcp.client.stdio import stdio_client
+from mcp.client.sse import sse_client
 import mcp.types as types
 
 import sys
@@ -21,15 +22,20 @@ logger = logging.getLogger("mcp_host")
 
 class MCPConnection:
     """
-    Manages the connection to an MCP Server via Stdio.
+    Manages the connection to an MCP Server via Stdio or SSE.
     Acts as a generic MCP Host.
     """
-    def __init__(self, server_command: str, server_args: List[str], env: Optional[Dict[str, str]] = None):
-        self.server_params = StdioServerParameters(
-            command=server_command,
-            args=server_args,
-            env=env or os.environ.copy()
-        )
+    def __init__(self, server_command: str = None, server_args: List[str] = None, env: Optional[Dict[str, str]] = None, url: str = None):
+        self.server_params = None
+        self.url = url
+        
+        if server_command:
+            self.server_params = StdioServerParameters(
+                command=server_command,
+                args=server_args or [],
+                env=env or os.environ.copy()
+            )
+            
         self.session: Optional[ClientSession] = None
         self.exit_stack = AsyncExitStack()
         self.tools: List[Any] = []
@@ -60,13 +66,24 @@ class MCPConnection:
 
     async def connect(self):
         """Establishes the connection to the MCP Server."""
-        logger.info(f"Connecting to MCP Server: {self.server_params.command} {self.server_params.args}")
+        if self.url:
+             logger.info(f"Connecting to MCP Server via SSE: {self.url}")
+        elif self.server_params:
+             logger.info(f"Connecting to MCP Server via Stdio: {self.server_params.command} {self.server_params.args}")
+        else:
+             raise ValueError("No connection parameters (command or url) provided.")
         
         try:
-            # 1. Start the stdio transport (NO stream interception - it breaks MCP SDK)
-            read, write = await self.exit_stack.enter_async_context(
-                stdio_client(self.server_params)
-            )
+            if self.url:
+                # 1. Start SSE transport
+                read, write = await self.exit_stack.enter_async_context(
+                    sse_client(self.url)
+                )
+            else:
+                # 1. Start stdio transport
+                read, write = await self.exit_stack.enter_async_context(
+                    stdio_client(self.server_params)
+                )
             
             # 2. Create the session
             self.session = await self.exit_stack.enter_async_context(
@@ -185,6 +202,11 @@ def create_connection_from_config(server_name: str = "agentbell-voice") -> MCPCo
         
     server_config = config["mcpServers"][server_name]
     
+    # Check for SSE config (url)
+    if "url" in server_config:
+        return MCPConnection(url=server_config["url"])
+    
+    # Fallback to Stdio config (command)
     # Fix command: Use sys.executable if command is 'python' or 'python3'
     # This ensures the subprocess uses the same virtual environment as the host
     cmd = server_config["command"]