Function fetch_session_mcp_tools

core/src/agent_api/capabilities.rs:256–266

(mcp: &Arc<McpManager>)

}

fn fetch_session_mcp_tools(mcp: &Arc<McpManager>) -> Vec<(String, McpTool)> {
    match tokio::runtime::Handle::try_current() {
        Ok(handle) => tokio::task::block_in_place(|| handle.block_on(mcp.get_all_tools())),
        Err(_) => {
            tracing::warn!(
                "No async runtime available for session-level MCP tools - MCP tools will not be registered"
            );
            vec![]
        }
    }
}

fn group_mcp_tools_by_server(all_tools: Vec<(String, McpTool)>) -> HashMap<String, Vec<McpTool>> {
    let mut by_server = HashMap::new();