feat: update mcp server status

Author: damassi

agent-chat-cli.config.yaml

@@ -24,7 +24,7 @@ mcp_servers:
     description: "Browser automation and debugging capabilities for AI agents"
     command: "npx"
     args:
-      - "chrome-devtools-mcp@latest"
+      - "chrome-devtools-mcpp@latest"
     disallowed_tools: []
     enabled: true
 

src/agent_chat_cli/components/header.py

@@ -4,6 +4,7 @@
 
 from agent_chat_cli.components.spacer import Spacer
 from agent_chat_cli.utils.config import load_config
+from agent_chat_cli.utils.mcp_server_status import MCPServerStatus
 
 
 class Header(Widget):
@@ -18,7 +19,8 @@ def compose(self) -> ComposeResult:
         )
 
         yield Label(
-            f"[dim]Available MCP Servers:[/dim] {mcp_servers}",
+            f"[dim]Available MCP Servers: {mcp_servers}[/dim]",
+            id="header-mcp-servers",
         )
 
         if agents:
@@ -35,3 +37,29 @@ def compose(self) -> ComposeResult:
             id="header-instructions",
             classes="header-instructions",
         )
+
+    def on_mount(self) -> None:
+        MCPServerStatus.subscribe(self._handle_mcp_server_status)
+
+    def on_unmount(self) -> None:
+        MCPServerStatus.unsubscribe(self._handle_mcp_server_status)
+
+    def _handle_mcp_server_status(self) -> None:
+        config = load_config()
+        server_names = list(config.mcp_servers.keys())
+
+        server_parts = []
+        for name in server_names:
+            is_connected = MCPServerStatus.is_connected(name)
+
+            if is_connected:
+                server_parts.append(f"{name}")
+            else:
+                # Error connecting to MCP
+                server_parts.append(f"[#ffa2dc][strike]{name}[/strike][/]")
+
+        mcp_servers = ", ".join(server_parts)
+        markup = f"[dim]Available MCP Servers:[/dim] {mcp_servers}"
+
+        label = self.query_one("#header-mcp-servers", Label)
+        label.update(markup)

src/agent_chat_cli/core/agent_loop.py

@@ -25,6 +25,7 @@
 from agent_chat_cli.utils.enums import AgentMessageType, ContentType, ControlCommand
 from agent_chat_cli.core.mcp_inference import infer_mcp_servers
 from agent_chat_cli.utils.logger import log_json
+from agent_chat_cli.utils.mcp_server_status import MCPServerStatus
 
 if TYPE_CHECKING:
     from agent_chat_cli.app import AgentChatCLIApp
@@ -164,6 +165,9 @@ async def _handle_message(self, message: Any) -> None:
                 # When initializing the chat, we store the session_id for later
                 self.session_id = message.data["session_id"]
 
+                # Report status back to UI
+                MCPServerStatus.update(message.data["mcp_servers"])
+
         # Handle streaming messages
         if hasattr(message, "event"):
             event = message.event  # type: ignore[attr-defined]
@@ -215,7 +219,7 @@ async def _can_use_tool(
         self,
         tool_name: str,
         tool_input: dict[str, Any],
-        context: ToolPermissionContext,
+        _context: ToolPermissionContext,
     ) -> PermissionResult:
         """Agent SDK handler for tool use permissions"""
 

src/agent_chat_cli/core/styles.tcss

@@ -10,7 +10,7 @@ MarkdownH6 {
 }
 
 Screen {
-    background: transparent;
+    background: #222;
 }
 
 Spacer {

src/agent_chat_cli/utils/mcp_server_status.py

@@ -0,0 +1,34 @@
+from typing import Any, Callable
+
+
+class MCPServerStatus:
+    # After the first query is sent, claude agent sdk sends back an init payload which
+    # with various statuses. In it, we can see mcp connection success or failure.
+    _mcp_servers: list[dict[str, Any]] = []
+
+    # Register component callbacks that need access to the status
+    _callbacks: list[Callable[[], None]] = []
+
+    @classmethod
+    def update(cls, mcp_servers: list[dict[str, Any]]) -> None:
+        cls._mcp_servers = mcp_servers
+
+        for callback in cls._callbacks:
+            callback()
+
+    @classmethod
+    def is_connected(cls, server_name: str) -> bool:
+        for server in cls._mcp_servers:
+            if server.get("name") == server_name:
+                return server.get("status") == "connected"
+
+        return False
+
+    @classmethod
+    def subscribe(cls, callback: Callable[[], None]) -> None:
+        cls._callbacks.append(callback)
+
+    @classmethod
+    def unsubscribe(cls, callback: Callable[[], None]) -> None:
+        if callback in cls._callbacks:
+            cls._callbacks.remove(callback)