Method new

crates/chat-cli/src/cli/chat/mod.rs:687–821

(
        os: &mut Os,
        conversation_id: &str,
        mut agents: Agents,
        mut input: Option<String>,
        input_source: InputSource,
        resume_conversation: bool,
        termi

impl ChatSession {
    #[allow(clippy::too_many_arguments)]
    pub async fn new(
        os: &mut Os,
        conversation_id: &str,
        mut agents: Agents,
        mut input: Option<String>,
        input_source: InputSource,
        resume_conversation: bool,
        terminal_width_provider: fn() -> Option<usize>,
        tool_manager: ToolManager,
        model_id: Option<String>,
        tool_config: HashMap<String, ToolSpec>,
        interactive: bool,
        mcp_enabled: bool,
        wrap: Option<WrapMode>,
    ) -> Result<Self> {
        // Only load prior conversation if we need to resume
        let mut existing_conversation = false;

        let should_send_structured_msg = should_send_structured_message(os);
        let (view_end, _byte_receiver, mut control_end_stderr, control_end_stdout) =
            get_legacy_conduits(should_send_structured_msg);
        let (prompt_ack_tx, prompt_ack_rx) = std::sync::mpsc::channel::<()>();

        tokio::task::spawn_blocking(move || {
            let stderr = std::io::stderr();
            let stdout = std::io::stdout();
            if let Err(e) = view_end.into_legacy_mode(StyledText, Some(prompt_ack_tx), stderr, stdout) {
                error!("Conduit view end legacy mode exited: {:?}", e);
            }
        });

        let conversation = match resume_conversation {
            true => {
                let previous_conversation = std::env::current_dir()
                    .ok()
                    .and_then(|cwd| os.database.get_conversation_by_path(cwd).ok())
                    .flatten();

                // Only restore conversations where there were actual messages
                // Prevents edge case where user clears conversation then exits without chatting.
                match previous_conversation.filter(|cs| !cs.history().is_empty()) {
                    Some(mut cs) => {
                        existing_conversation = true;
                        input = Some(input.unwrap_or("In a few words, summarize our conversation so far.".to_owned()));
                        cs.tool_manager = tool_manager;
                        if let Some(profile) = cs.current_profile() {
                            if agents.switch(profile).is_err() {
                                execute!(
                                    &mut control_end_stderr,
                                    StyledText::error_fg(),
                                    style::Print("Error"),
                                    StyledText::reset(),
                                    style::Print(format!(
                                        ": cannot resume conversation with {profile} because it no longer exists. Using default.\n"
                                    ))
                                )?;
                                let _ = agents.switch(DEFAULT_AGENT_NAME);
                            }