Method build

crates/chat-cli/src/cli/chat/tool_manager.rs:276–464

Creates a [ToolManager] based on the current fields populated, which consists of the following: - Instantiates child processes associated with the list of mcp servers in scope - Spawns a loading display task that is used to show server loading status (if applicable) - Spawns the orchestrator task (see [spawn_orchestrator_task] for more detail) (if applicable) - Finally, creates an instance of [Too

(
        mut self,
        os: &mut Os,
        mut output: Box<dyn Write + Send + Sync + 'static>,
        interactive: bool,
    )

    ///   applicable)
    /// - Finally, creates an instance of [ToolManager]
    pub async fn build(
        mut self,
        os: &mut Os,
        mut output: Box<dyn Write + Send + Sync + 'static>,
        interactive: bool,
    ) -> eyre::Result<ToolManager> {
        let McpServerConfig { mcp_servers } = match &self.agent {
            Some(agent) => agent.lock().await.mcp_servers.clone(),
            None => Default::default(),
        };
        debug_assert!(self.conversation_id.is_some());
        let conversation_id = self.conversation_id.ok_or(eyre::eyre!("Missing conversation id"))?;

        // Separate enabled and disabled servers
        let (enabled_servers, disabled_servers): (Vec<_>, Vec<_>) = mcp_servers
            .into_iter()
            .partition(|(_, server_config)| !server_config.disabled);

        // Prepare disabled servers for display
        let disabled_servers_display: Vec<String> = disabled_servers
            .iter()
            .map(|(server_name, _)| server_name.clone())
            .collect();

        let pre_initialized = enabled_servers
            .iter()
            .filter(|(server_name, _)| {
                if server_name == "builtin" {
                    let _ = queue!(
                        output,
                        StyledText::error_fg(),
                        style::Print("✗ Invalid server name "),
                        StyledText::info_fg(),
                        style::Print(&server_name),
                        StyledText::reset(),
                        style::Print(". Server name cannot contain reserved word "),
                        StyledText::warning_fg(),
                        style::Print("builtin"),
                        StyledText::reset(),
                        style::Print(" (it is used to denote native tools)\n")
                    );
                    false
                } else {
                    true
                }
            })
            .collect::<Vec<_>>();

        let mut clients = HashMap::<String, InitializedMcpClient>::new();
        let new_tool_specs = self.new_tool_specs;
        let has_new_stuff = self.has_new_stuff;
        let pending = self.pending_clients.unwrap_or(Arc::new(RwLock::new({
            let mut pending = HashSet::<String>::new();
            pending.extend(pre_initialized.iter().map(|(name, _)| name.clone()));
            pending
        })));
        let notify = Arc::new(Notify::new());
        let load_record = self.mcp_load_record;