From 06a0b36ee5f238ef71184131599c7d4533acc078 Mon Sep 17 00:00:00 2001 From: jif-oai Date: Wed, 24 Sep 2025 18:13:18 +0100 Subject: [PATCH] ref: state 9 (#4171) --- codex-rs/core/src/codex.rs | 5 +++++ codex-rs/core/src/codex/compact.rs | 5 +---- 2 files changed, 6 insertions(+), 4 deletions(-) diff --git a/codex-rs/core/src/codex.rs b/codex-rs/core/src/codex.rs index 2a5a7d0203..ae881d8b43 100644 --- a/codex-rs/core/src/codex.rs +++ b/codex-rs/core/src/codex.rs @@ -715,6 +715,11 @@ impl Session { state.record_items(items.iter()); } + async fn replace_history(&self, items: Vec) { + let mut state = self.state.lock().await; + state.replace_history(items); + } + async fn persist_rollout_response_items(&self, items: &[ResponseItem]) { let rollout_items: Vec = items .iter() diff --git a/codex-rs/core/src/codex/compact.rs b/codex-rs/core/src/codex/compact.rs index 116113df95..4facd45d5d 100644 --- a/codex-rs/core/src/codex/compact.rs +++ b/codex-rs/core/src/codex/compact.rs @@ -156,10 +156,7 @@ async fn run_compact_task_inner( let user_messages = collect_user_messages(&history_snapshot); let initial_context = sess.build_initial_context(turn_context.as_ref()); let new_history = build_compacted_history(initial_context, &user_messages, &summary_text); - { - let mut state = sess.state.lock().await; - state.replace_history(new_history); - } + sess.replace_history(new_history).await; let rollout_item = RolloutItem::Compacted(CompactedItem { message: summary_text.clone(),