Function copy_lfs_objects

src/git.rs:49–82

Recursively copy LFS objects from source to destination, skipping files that already exist. LFS objects are content-addressed, so existing files are guaranteed to have identical content.

(src: &Path, dst: &Path)

/// Recursively copy LFS objects from source to destination, skipping files that already exist.
/// LFS objects are content-addressed, so existing files are guaranteed to have identical content.
async fn copy_lfs_objects(src: &Path, dst: &Path) -> Result<(), String> {
    if !src.exists() {
        return Ok(());
    }

    let mut entries = tokio::fs::read_dir(src)
        .await
        .map_err(|e| format!("Failed to read LFS objects dir: {e}"))?;

    while let Ok(Some(entry)) = entries.next_entry().await {
        let src_path = entry.path();
        let file_name = entry.file_name();
        let dst_path = dst.join(&file_name);

        let meta = tokio::fs::symlink_metadata(&src_path)
            .await
            .map_err(|e| format!("Failed to stat {}: {e}", src_path.display()))?;

        if meta.is_dir() {
            Box::pin(copy_lfs_objects(&src_path, &dst_path)).await?;
        } else if meta.is_file() && !dst_path.exists() {
            if let Some(parent) = dst_path.parent() {
                crate::file_system::create_dir(parent)
                    .await
                    .map_err(|e| format!("Failed to create LFS dir: {e}"))?;
            }
            crate::file_system::copy_file(&src_path, &dst_path)
                .await
                .map_err(|e| format!("Failed to copy LFS object: {e}"))?;
        }
    }

    Ok(())
}

impl RepoManager {
    /// Creates a new RepoManager from the application context.