Function ensure_session_for_thread_goal

src/apps/desktop/src/api/agentic_api.rs:979–1017

(
    coordinator: &Arc<ConversationCoordinator>,
    app_state: &AppState,
    session_id: &str,
    workspace_path: Option<&str>,
    remote_connection_id: Option<&str>,
    remote_ssh_host: Option<

}

async fn ensure_session_for_thread_goal(
    coordinator: &Arc<ConversationCoordinator>,
    app_state: &AppState,
    session_id: &str,
    workspace_path: Option<&str>,
    remote_connection_id: Option<&str>,
    remote_ssh_host: Option<&str>,
) -> Result<PathBuf, String> {
    if coordinator
        .get_session_manager()
        .get_session(session_id)
        .is_none()
    {
        let workspace_path = workspace_path
            .map(str::trim)
            .filter(|value| !value.is_empty())
            .ok_or_else(|| {
                "workspace_path is required when the session is not loaded".to_string()
            })?;
        let effective = desktop_effective_session_storage_path(
            app_state,
            workspace_path,
            remote_connection_id,
            remote_ssh_host,
        )
        .await;
        coordinator
            .restore_session_from_storage_path(&effective, session_id)
            .await
            .map_err(|e| format!("Failed to restore session before thread goal access: {e}"))?;
    }

    coordinator
        .get_session_manager()
        .get_session(session_id)
        .and_then(|session| session.config.workspace_path.clone())
        .map(PathBuf::from)
        .ok_or_else(|| format!("Session workspace_path is missing: {session_id}"))
}

async fn resolve_thread_goal_storage_path(
    coordinator: &Arc<ConversationCoordinator>,