Function restore_session_view

src/apps/desktop/src/api/agentic_api.rs:1763–1892

(
    coordinator: State<'_, Arc<ConversationCoordinator>>,
    app_state: State<'_, AppState>,
    startup_trace: State<'_, DesktopStartupTrace>,
    request: RestoreSessionRequest,
)

#[tauri::command]
pub async fn restore_session_view(
    coordinator: State<'_, Arc<ConversationCoordinator>>,
    app_state: State<'_, AppState>,
    startup_trace: State<'_, DesktopStartupTrace>,
    request: RestoreSessionRequest,
) -> Result<RestoreSessionViewResponse, String> {
    let started_at = Instant::now();
    let result = async {
        let trace_id = request.trace_id.as_deref().unwrap_or("none");
        debug!(
            "restore_session_view request received: trace_id={}, session_id={}",
            trace_id, request.session_id
        );
        let path_started_at = Instant::now();
        let effective_path = desktop_effective_session_storage_path(
            &app_state,
            &request.workspace_path,
            request.remote_connection_id.as_deref(),
            request.remote_ssh_host.as_deref(),
        )
        .await;
        let resolve_storage_path_duration_ms =
            path_started_at.elapsed().as_millis().min(u64::MAX as u128) as u64;
        debug!(
            "restore_session_view storage path resolved: trace_id={}, session_id={}, duration_ms={}",
            trace_id,
            request.session_id,
            resolve_storage_path_duration_ms
        );

        let session_storage_path = effective_path;
        let tail_turn_count = request
            .tail_turn_count
            .filter(|count| *count > 0)
            .map(|count| count.min(16));
        let (session, mut turns, total_turn_count, mut timings) =
            if let Some(tail_turn_count) = tail_turn_count {
                if request.include_internal {
                    coordinator
                        .restore_internal_session_view_from_storage_path_tail_timed(
                            &session_storage_path,
                            &request.session_id,
                            tail_turn_count,
                        )
                        .await
                } else {
                    coordinator
                        .restore_session_view_from_storage_path_tail_timed(
                            &session_storage_path,
                            &request.session_id,
                            tail_turn_count,
                        )
                        .await
                }
            } else if request.include_internal {
                coordinator
                    .restore_internal_session_view_from_storage_path_timed(
                        &session_storage_path,