fix(tui): bound history loaded on resume

Author: jezell

codex-rs/tui/src/app_server_session.rs

@@ -50,6 +50,7 @@ use codex_app_server_protocol::ReviewTarget;
 use codex_app_server_protocol::SessionSource;
 use codex_app_server_protocol::SkillsListParams;
 use codex_app_server_protocol::SkillsListResponse;
+use codex_app_server_protocol::SortDirection;
 use codex_app_server_protocol::Thread;
 use codex_app_server_protocol::ThreadApproveGuardianDeniedActionParams;
 use codex_app_server_protocol::ThreadApproveGuardianDeniedActionResponse;
@@ -84,6 +85,7 @@ use codex_app_server_protocol::ThreadMetadataUpdateParams;
 use codex_app_server_protocol::ThreadMetadataUpdateResponse;
 use codex_app_server_protocol::ThreadReadParams;
 use codex_app_server_protocol::ThreadReadResponse;
+use codex_app_server_protocol::ThreadResumeInitialTurnsPageParams;
 use codex_app_server_protocol::ThreadResumeParams;
 use codex_app_server_protocol::ThreadResumeResponse;
 use codex_app_server_protocol::ThreadSetNameParams;
@@ -103,6 +105,7 @@ use codex_app_server_protocol::ThreadUnsubscribeResponse;
 use codex_app_server_protocol::Turn;
 use codex_app_server_protocol::TurnInterruptParams;
 use codex_app_server_protocol::TurnInterruptResponse;
+use codex_app_server_protocol::TurnItemsView;
 use codex_app_server_protocol::TurnStartParams;
 use codex_app_server_protocol::TurnStartResponse;
 use codex_app_server_protocol::TurnSteerParams;
@@ -138,6 +141,7 @@ const JSONRPC_INVALID_REQUEST: i64 = -32600;
 const JSONRPC_METHOD_NOT_FOUND: i64 = -32601;
 pub(crate) const EXTERNAL_AGENT_CONFIG_IMPORT_IN_PROGRESS_MESSAGE: &str = "A previous external agent import is still running. Wait for it to finish before importing again.";
 const THREAD_SETTINGS_UPDATE_METHOD: &str = "thread/settings/update";
+const TUI_RESUME_INITIAL_TURN_LIMIT: u32 = 100;
 
 #[derive(Clone, Copy, Debug, Eq, PartialEq)]
 pub(crate) enum ForkGoalContinuation {
@@ -1586,6 +1590,12 @@ fn thread_resume_params_from_config(
         developer_instructions: with_terminal_visualization_instructions(
             &config, /*control_instructions*/ None,
         ),
+        exclude_turns: true,
+        initial_turns_page: Some(ThreadResumeInitialTurnsPageParams {
+            limit: Some(TUI_RESUME_INITIAL_TURN_LIMIT),
+            sort_direction: Some(SortDirection::Desc),
+            items_view: Some(TurnItemsView::Summary),
+        }),
         ..ThreadResumeParams::default()
     }
 }
@@ -1669,9 +1679,15 @@ async fn started_thread_from_resume_response(
         thread_session_state_from_thread_resume_response(&response, config, thread_params_mode)
             .await
             .map_err(color_eyre::eyre::Report::msg)?;
+    let turns = response
+        .initial_turns_page
+        .map_or(response.thread.turns, |mut page| {
+            page.data.reverse();
+            page.data
+        });
     Ok(AppServerStartedThread {
         session,
-        turns: response.thread.turns,
+        turns,
         blocks_direct_input,
     })
 }
@@ -2382,6 +2398,30 @@ mod tests {
         assert_eq!(fork.config, Some(expected_config));
     }
 
+    #[tokio::test]
+    async fn thread_resume_params_request_bounded_summary_history() {
+        let temp_dir = tempfile::tempdir().expect("tempdir");
+        let config = build_config(&temp_dir).await;
+
+        let params = thread_resume_params_from_config(
+            config,
+            ThreadId::new(),
+            ThreadParamsMode::Embedded,
+            /*remote_cwd_override*/ None,
+            ResumeModelSettings::RestoreFromThread,
+        );
+
+        assert!(params.exclude_turns);
+        assert_eq!(
+            params.initial_turns_page,
+            Some(ThreadResumeInitialTurnsPageParams {
+                limit: Some(TUI_RESUME_INITIAL_TURN_LIMIT),
+                sort_direction: Some(SortDirection::Desc),
+                items_view: Some(TurnItemsView::Summary),
+            })
+        );
+    }
+
     #[tokio::test]
     async fn thread_resume_params_can_restore_persisted_model_settings() {
         let temp_dir = tempfile::tempdir().expect("tempdir");
@@ -2786,6 +2826,38 @@ mod tests {
         .expect("embedded resume response should map");
         assert_eq!(started.session.permission_profile, read_only_profile);
 
+        let initial_page_turn = Turn {
+            id: "turn-2".to_string(),
+            items_view: TurnItemsView::Summary,
+            items: vec![codex_app_server_protocol::ThreadItem::AgentMessage {
+                id: "assistant-2".to_string(),
+                text: "latest assistant reply".to_string(),
+                phase: None,
+                memory_citation: None,
+            }],
+            status: TurnStatus::Completed,
+            error: None,
+            started_at: None,
+            completed_at: None,
+            duration_ms: None,
+        };
+        let mut initial_page_older_turn = initial_page_turn.clone();
+        initial_page_older_turn.id = "turn-1".to_string();
+        let mut paged_response = response.clone();
+        paged_response.initial_turns_page = Some(codex_app_server_protocol::TurnsPage {
+            data: vec![initial_page_turn.clone(), initial_page_older_turn.clone()],
+            next_cursor: None,
+            backwards_cursor: Some("older-turns".to_string()),
+        });
+        let started =
+            started_thread_from_resume_response(paged_response, &config, ThreadParamsMode::Remote)
+                .await
+                .expect("paged resume response should map");
+        assert_eq!(
+            started.turns,
+            vec![initial_page_older_turn, initial_page_turn]
+        );
+
         let mut empty_roots_response = response;
         empty_roots_response.runtime_workspace_roots = Vec::new();
         let started = started_thread_from_resume_response(