liboxen 0.9.4-beta3

//! # oxen commit-cache
//!
//! Compute the cache for a commits, used from the CLI for migrations on commits that
//! were created before the cache was introduced.
//!

use std::path::Path;

use crate::api;
use crate::core::cache;
use crate::error::OxenError;
use crate::model::LocalRepository;
use crate::opts::LogOpts;

/// Run the computation cache on all repositories within a directory
pub async fn compute_cache_on_all_repos(path: &Path, force: bool) -> Result<(), OxenError> {
    let namespaces = api::local::repositories::list_namespaces(path)?;
    for namespace in namespaces {
        let namespace_path = path.join(namespace);
        let repos = api::local::repositories::list_repos_in_namespace(&namespace_path);
        for repo in repos {
            println!("Compute cache for repo {:?}", repo.path);
            match compute_cache(&repo, None, force).await {
                Ok(_) => {
                    println!("Done.");
                }
                Err(err) => {
                    log::error!(
                        "Could not compute cache for repo {:?}\nErr: {}",
                        repo.path,
                        err
                    )
                }
            }
        }
    }

    Ok(())
}

/// Run the computation cache on all repositories within a directory
pub async fn compute_cache(
    repo: &LocalRepository,
    revision: Option<String>,
    force: bool,
) -> Result<(), OxenError> {
    println!(
        "Compute cache for commit given [{revision:?}] on repo {:?}",
        repo.path
    );
    let commits = if let Some(revision) = revision {
        let opts = LogOpts {
            revision: Some(revision),
            remote: false,
        };
        api::local::commits::list_with_opts(repo, &opts).await?
    } else {
        api::local::commits::list_all(repo)?
    };
    for commit in commits {
        println!("Compute cache for commit {:?}", commit);
        cache::commit_cacher::run_all(repo, &commit, force)?;
    }
    Ok(())
}