Function cleanup_invalid_workspaces_impl

src/apps/desktop/src/api/commands.rs:2108–2179

(
    state: &State<'_, AppState>,
    app: &tauri::AppHandle,
    startup_trace: &State<'_, DesktopStartupTrace>,
    trace_step_prefix: &str,
    command_name: Option<&str>,
    command_started: Ins

}

async fn cleanup_invalid_workspaces_impl(
    state: &State<'_, AppState>,
    app: &tauri::AppHandle,
    startup_trace: &State<'_, DesktopStartupTrace>,
    trace_step_prefix: &str,
    command_name: Option<&str>,
    command_started: Instant,
) -> Result<usize, String> {
    let cleanup_started = Instant::now();
    match state.workspace_service.cleanup_invalid_workspaces().await {
        Ok(local_removed_count) => {
            startup_trace.record_elapsed_step(
                "tauri_command",
                format!("{trace_step_prefix}.local_workspace_cleanup"),
                cleanup_started,
            );
            let prune_remote_started = Instant::now();
            let remote_removed_count = prune_unrecoverable_remote_workspaces(state).await;
            startup_trace.record_elapsed_step(
                "tauri_command",
                format!("{trace_step_prefix}.remote_workspace_prune"),
                prune_remote_started,
            );
            let removed_count = local_removed_count + remote_removed_count;

            let apply_context_started = Instant::now();
            if let Some(workspace_info) = state.workspace_service.get_current_workspace().await {
                apply_active_workspace_context(&state, &app, &workspace_info, None).await;
            } else {
                clear_active_workspace_context(&state, &app, None).await;
            }
            startup_trace.record_elapsed_step(
                "tauri_command",
                format!("{trace_step_prefix}.apply_active_workspace_context"),
                apply_context_started,
            );

            let sync_watchers_started = Instant::now();
            if let Err(e) = state
                .workspace_identity_watch_service
                .sync_watched_workspaces()
                .await
            {
                warn!(
                    "Failed to sync workspace identity watchers after workspace cleanup: {}",
                    e
                );
            }
            startup_trace.record_elapsed_step(
                "tauri_command",
                format!("{trace_step_prefix}.sync_identity_watchers"),
                sync_watchers_started,
            );

            info!(
                "Invalid workspaces cleaned up: removed_count={}",
                removed_count
            );