Method compact_history_impl

crates/chat-cli/src/cli/chat/mod.rs:1532–1779

(
        &mut self,
        os: &mut Os,
        custom_prompt: Option<String>,
        show_summary: bool,
        strategy: CompactStrategy,
        request_metadata_lock: Arc<Mutex<Option<RequestM

    }

    async fn compact_history_impl(
        &mut self,
        os: &mut Os,
        custom_prompt: Option<String>,
        show_summary: bool,
        strategy: CompactStrategy,
        request_metadata_lock: Arc<Mutex<Option<RequestMetadata>>>,
    ) -> Result<ChatState, ChatError> {
        let hist = self.conversation.history();
        debug!(?strategy, ?hist, "compacting history");

        if self.conversation.history().is_empty() {
            execute!(
                self.stderr,
                StyledText::warning_fg(),
                style::Print("\nConversation too short to compact.\n\n"),
                StyledText::reset(),
            )?;

            return Ok(ChatState::PromptUser {
                skip_printing_tools: true,
            });
        }

        if strategy.truncate_large_messages {
            info!("truncating large messages");
            execute!(
                self.stderr,
                terminal::Clear(terminal::ClearType::CurrentLine),
                cursor::MoveToColumn(0),
                StyledText::warning_fg(),
                style::Print("Truncating large messages..."),
                StyledText::reset_attributes(),
                style::Print("\n\n"),
            )?;
        }

        let summary_state = self
            .conversation
            .create_summary_request(os, custom_prompt.as_ref(), strategy)
            .await?;

        if self.interactive {
            self.spinner = Some(Spinner::new(Spinners::Dots, "Creating summary...".to_string()));
        }

        let mut response = match self
            .send_message(
                os,
                summary_state,
                request_metadata_lock,
                Some(vec![MessageMetaTag::Compact]),
            )
            .await
        {
            Ok(res) => res,
            Err(err) => {
                if self.interactive {