fix(mcp): resolve server query parameter error and enable stateless HTTP

- Fix FastAPI dependency injection in maibot action endpoint (missing Depends)
- Fix FastMCP run method: use run_async with stateless_http=True instead of run_http_async
- Fix port from invalid 80214 to valid 8021 across config and code
- Add proper asyncio.wait_for with timeout in cleanup for graceful shutdown

Author: ChangingSelf

config-template.toml

@@ -385,4 +385,4 @@ enable_validation = false
 [mcp]
 enabled = false
 host = "127.0.0.1"
-port = 80214
+port = 8021

src/modules/dashboard/api/maibot.py

@@ -8,15 +8,15 @@
 import uuid
 from typing import TYPE_CHECKING
 
-from fastapi import APIRouter, HTTPException, status
+from fastapi import APIRouter, Depends, HTTPException, status
 
+from src.modules.dashboard.dependencies import get_dashboard_server
 from src.modules.dashboard.schemas.maibot import MaibotActionRequest, MaibotActionResponse
 from src.modules.events.names import CoreEvents
 from src.modules.events.payloads.decision import IntentPayload
 from src.modules.logging import get_logger
 from src.modules.types.intent import Intent, IntentMetadata
 
-
 if TYPE_CHECKING:
     from src.modules.dashboard.server import DashboardServer
 
@@ -27,7 +27,7 @@
 @router.post("/action", response_model=MaibotActionResponse)
 async def handle_maibot_action(
     request: MaibotActionRequest,
-    server: "DashboardServer",
+    server: "DashboardServer" = Depends(get_dashboard_server),  # noqa: B008
 ) -> MaibotActionResponse:
     event_bus = server.event_bus
     if not event_bus:

src/modules/mcp/config.py

@@ -12,4 +12,4 @@ class MCPServerConfig(BaseModel):
 
     enabled: bool = Field(default=False, description="是否启用 MCP 服务")
     host: str = Field(default="127.0.0.1", description="MCP 服务监听地址")
-    port: int = Field(default=80214, description="MCP 服务监听端口")
+    port: int = Field(default=8021, description="MCP 服务监听端口（有效范围：1024-65535）")

src/modules/mcp/service.py

@@ -86,11 +86,12 @@ async def send_intent_tool(
             return await self._send_intent_internal(action, emotion, speech, context, priority)
 
         host = config.get("host", "127.0.0.1")
-        port = config.get("port", 80214)
+        port = config.get("port", 8021)
+
+        self.logger.info(f"启动 MCP 服务器: {host}:{port} (stateless_http=True)")
 
-        self.logger.info(f"启动 MCP 服务器: {host}:{port}")
         self._server_task = asyncio.create_task(
-            self._mcp.run_http_async(transport="streamable-http", host=host, port=port)
+            self._mcp.run_async(transport="http", host=host, port=port, stateless_http=True)
         )
 
         self._initialized = True
@@ -106,7 +107,9 @@ async def cleanup(self) -> None:
         if self._server_task:
             self._server_task.cancel()
             try:
-                await self._server_task
+                await asyncio.wait_for(self._server_task, timeout=5.0)
+            except asyncio.TimeoutError:
+                self.logger.warning("MCP 服务器关闭超时，强制取消")
             except asyncio.CancelledError:
                 pass