Method execute_mcp_toggle

src/apps/cli/src/modes/chat.rs:2340–2375

Execute MCP server toggle (called from main loop after render)

(
        &mut self,
        server_id: &str,
        chat_view: &mut ChatView,
        chat_state: &mut ChatState,
        rt_handle: &tokio::runtime::Handle,
    )

    /// Execute MCP server toggle (called from main loop after render)
    fn execute_mcp_toggle(
        &mut self,
        server_id: &str,
        chat_view: &mut ChatView,
        chat_state: &mut ChatState,
        rt_handle: &tokio::runtime::Handle,
    ) {
        let mcp_service = match crate::get_mcp_service() {
            Some(svc) => svc.clone(),
            None => {
                chat_state.add_system_message("MCP service not initialized".to_string());
                chat_view.mcp_selector_set_loading(None);
                return;
            }
        };

        let server_manager = mcp_service.server_manager();
        let task_server_id = server_id.to_string();
        let tracked_server_id = task_server_id.clone();

        let handle = rt_handle.spawn(async move {
            let status = server_manager.get_server_status(&task_server_id).await;
            match status {
                Ok(bitfun_core::service::mcp::MCPServerStatus::Connected)
                | Ok(bitfun_core::service::mcp::MCPServerStatus::Healthy) => {
                    server_manager.stop_server(&task_server_id).await
                }
                _ => server_manager.start_server(&task_server_id).await,
            }
        });

        self.pending_mcp_tasks.push(PendingMcpTask::Toggle {
            server_id: tracked_server_id,
            handle,
        });
    }

    fn is_mcp_server_task_running(&self, server_id: &str) -> bool {
        self.pending_mcp_tasks.iter().any(|task| match task {