mvx/

lib.rs

use anyhow::{Context, bail, ensure};
use colored::Colorize;
use log::LevelFilter;
use std::io::Write;
use std::path::Path;
use std::sync::Arc;
use std::sync::atomic::{AtomicBool, Ordering};

mod dir;
mod file;

#[derive(Debug, Clone, Copy)]
pub enum SourceKind {
    File,
    Dir,
}

impl SourceKind {
    #[must_use]
    pub(crate) fn done_arrow(self) -> colored::ColoredString {
        match self {
            Self::File => "→",
            Self::Dir => "↣",
        }
        .green()
        .bold()
    }
}

#[derive(Debug, Clone, Copy)]
pub enum MoveOrCopy {
    Move,
    Copy,
}

impl MoveOrCopy {
    #[must_use]
    pub const fn arrow(&self) -> &'static str {
        match self {
            Self::Move => "->",
            Self::Copy => "=>",
        }
    }

    #[must_use]
    pub const fn progress_chars(&self) -> &'static str {
        match self {
            Self::Move => "->-",
            Self::Copy => "=>=",
        }
    }
}

#[derive(Debug, Clone, Copy, Default)]
pub(crate) struct TransferStats {
    pub io_bytes: u64,
    pub fast_path_file_count: u64,
    pub fast_path_dir_count: u64,
}

impl TransferStats {
    /// Format fast-path counts as e.g. "1 directory", "3 files", "1 directory + 3 files".
    /// Returns `None` when both counts are zero.
    #[must_use]
    fn fast_path_summary(self) -> Option<String> {
        if self.fast_path_file_count == 0 && self.fast_path_dir_count == 0 {
            return None;
        }
        let mut parts = Vec::new();
        if self.fast_path_dir_count > 0 {
            let noun = if self.fast_path_dir_count == 1 {
                "directory"
            } else {
                "directories"
            };
            parts.push(format!("{} {noun}", self.fast_path_dir_count));
        }
        if self.fast_path_file_count > 0 {
            let noun = if self.fast_path_file_count == 1 {
                "file"
            } else {
                "files"
            };
            parts.push(format!("{} {noun}", self.fast_path_file_count));
        }
        Some(parts.join(" + "))
    }
}

impl std::ops::AddAssign for TransferStats {
    fn add_assign(&mut self, rhs: Self) {
        self.io_bytes += rhs.io_bytes;
        self.fast_path_file_count += rhs.fast_path_file_count;
        self.fast_path_dir_count += rhs.fast_path_dir_count;
    }
}

pub struct Ctx<'a> {
    pub moc: MoveOrCopy,
    pub force: bool,
    pub dry_run: bool,
    pub batch_size: usize,
    pub mp: &'a indicatif::MultiProgress,
    pub ctrlc: &'a AtomicBool,
}

impl Ctx<'_> {
    /// Dim the detail text when in a batch (batch summary is the primary output).
    #[must_use]
    pub fn maybe_dim(&self, s: String) -> String {
        if self.batch_size > 1 {
            s.dimmed().to_string()
        } else {
            s
        }
    }

    /// Format a completion message for a file or directory operation.
    #[must_use]
    pub(crate) fn done_message<Src: AsRef<Path>, Dest: AsRef<Path>>(
        &self,
        kind: SourceKind,
        stats: TransferStats,
        elapsed: std::time::Duration,
        src: Src,
        dest: Dest,
    ) -> String {
        let detail = format!(
            "{}: {}",
            self.done_stats(kind, stats, elapsed),
            message_with_arrow(src, dest, self.moc),
        );
        format!("{} {}", kind.done_arrow(), self.maybe_dim(detail))
    }

    #[must_use]
    fn done_stats(
        &self,
        kind: SourceKind,
        stats: TransferStats,
        elapsed: std::time::Duration,
    ) -> String {
        let verb = match (self.moc, kind) {
            (MoveOrCopy::Move, SourceKind::File) => "Moved",
            (MoveOrCopy::Move, SourceKind::Dir) => "Merged",
            (MoveOrCopy::Copy, _) => "Copied",
        };

        let fast_parts = stats.fast_path_summary();

        if stats.io_bytes > 0 {
            let fast_suffix = if let Some(summary) = &fast_parts {
                let label = match self.moc {
                    MoveOrCopy::Move => "renamed",
                    MoveOrCopy::Copy => "reflinked",
                };
                format!(", {summary} {label}")
            } else {
                String::new()
            };
            format!(
                "{verb} {} in {}{}{fast_suffix}",
                indicatif::HumanBytes(stats.io_bytes),
                indicatif::HumanDuration(elapsed),
                human_speed(stats.io_bytes, elapsed),
            )
        } else if let Some(summary) = &fast_parts {
            let label = match self.moc {
                MoveOrCopy::Move => "Renamed",
                MoveOrCopy::Copy => "Reflinked",
            };
            format!("{label} {summary} in {}", indicatif::HumanDuration(elapsed),)
        } else {
            format!("{verb} in {}", indicatif::HumanDuration(elapsed))
        }
    }
}

#[must_use]
pub fn init_logging(level_filter: LevelFilter) -> indicatif::MultiProgress {
    let mp = indicatif::MultiProgress::new();
    if level_filter < LevelFilter::Info {
        mp.set_draw_target(indicatif::ProgressDrawTarget::hidden());
    }
    let mp_clone = mp.clone();

    env_logger::Builder::new()
        .filter_level(level_filter)
        .format(move |buf, record| {
            let ts = chrono::Local::now().to_rfc3339().bold();

            let file_and_line = format!(
                "[{}:{}]",
                record
                    .file()
                    .map(Path::new)
                    .and_then(Path::file_name)
                    .unwrap_or_default()
                    .display(),
                record.line().unwrap_or(0),
            )
            .italic();
            let level = match record.level() {
                log::Level::Error => "ERROR".red(),
                log::Level::Warn => "WARN ".yellow(),
                log::Level::Info => "INFO ".green(),
                log::Level::Debug => "DEBUG".blue(),
                log::Level::Trace => "TRACE".magenta(),
            }
            .bold();

            let msg = format!("{ts} {file_and_line:12} {level} {}", record.args());
            if mp_clone.is_hidden() {
                writeln!(buf, "{msg}")
            } else {
                mp_clone.println(msg)
            }
        })
        .init();

    mp
}

fn validate_sources(srcs: &[&Path], dest: &Path) -> anyhow::Result<SourceKind> {
    let mut all_files = true;
    let mut all_dirs = true;
    for src in srcs {
        if src.is_file() {
            all_dirs = false;
        } else if src.is_dir() {
            all_files = false;
        } else {
            bail!(
                "Source path '{}' is neither a file nor directory.",
                src.display()
            );
        }
    }

    if srcs.len() > 1 {
        ensure!(
            all_files || all_dirs,
            "When there are multiple sources, they must be all files or all directories.",
        );
        if !dest.is_dir() {
            if all_dirs || dest.to_string_lossy().ends_with('/') {
                std::fs::create_dir_all(dest)?;
            } else {
                bail!(
                    "When there are multiple file sources, the destination must be a directory or end with '/'."
                );
            }
        }
    }

    Ok(if all_files {
        SourceKind::File
    } else {
        SourceKind::Dir
    })
}

fn process_source(
    src: &Path,
    dest: &Path,
    batch_pb: &indicatif::ProgressBar,
    base: u64,
    sized: bool,
    ctx: &Ctx,
) -> anyhow::Result<(String, TransferStats)> {
    let progress = move |bytes: u64| {
        if sized {
            batch_pb.set_position(base + bytes);
        }
    };
    if src.is_file() {
        file::move_or_copy(src, dest, progress, ctx)
    } else {
        dir::merge_or_copy(src, dest, progress, ctx)
    }
}

/// # Errors
///
/// Will return `Err` if move/merge fails for any reason.
pub fn run_batch<Src: AsRef<Path>, Srcs: AsRef<[Src]>, Dest: AsRef<Path>>(
    srcs: Srcs,
    dest: Dest,
    ctx: &Ctx,
) -> anyhow::Result<String> {
    let srcs = srcs
        .as_ref()
        .iter()
        .map(std::convert::AsRef::as_ref)
        .collect::<Vec<_>>();
    let dest = dest.as_ref();
    log::trace!(
        "run_batch('{:?}', '{}', {:?})",
        srcs.iter().map(|s| s.display()).collect::<Vec<_>>(),
        dest.display(),
        ctx.moc,
    );

    let kind = validate_sources(&srcs, dest)?;

    if ctx.dry_run {
        for src in srcs {
            let action = match (ctx.moc, src.is_dir()) {
                (MoveOrCopy::Move, true) => "merge",
                (MoveOrCopy::Move, false) => "move",
                (MoveOrCopy::Copy, _) => "copy",
            };
            println!("Would {action} '{}' to '{}'", src.display(), dest.display());
        }
        return Ok(String::new());
    }

    let n = srcs.len();
    let sizes: Vec<u64> = srcs
        .iter()
        .map(|s| {
            let skip =
                matches!(ctx.moc, MoveOrCopy::Move) && s.is_dir() && dir::same_device(s, dest);
            if skip { 0 } else { source_size(s) }
        })
        .collect();
    let batch_pb = if n > 1 {
        ctx.mp
            .add(bytes_progress_bar(sizes.iter().sum(), "blue", ctx.moc))
    } else {
        indicatif::ProgressBar::hidden()
    };

    let batch_timer = std::time::Instant::now();
    let mut cumulative: u64 = 0;
    let mut batch_stats = TransferStats::default();
    for (i, src) in srcs.iter().enumerate() {
        if ctx.ctrlc.load(Ordering::Relaxed) {
            log::error!(
                "{FAIL_MARK} Cancelled: {}",
                message_with_arrow(src, dest, ctx.moc)
            );
            std::process::exit(130);
        }

        let up_next = srcs
            .get(i + 1)
            .map(|s| {
                format!(
                    " Up Next: {}",
                    s.file_name().unwrap_or(s.as_os_str()).to_string_lossy()
                )
                .dimmed()
            })
            .unwrap_or_default();
        batch_pb.set_message(format!("[{}/{}]{up_next}", i + 1, n));

        let (msg, stats) = process_source(src, dest, &batch_pb, cumulative, sizes[i] > 0, ctx)
            .with_context(|| message_with_arrow(src, dest, ctx.moc))?;
        batch_stats += stats;

        cumulative += sizes[i];
        batch_pb.set_position(cumulative);
        ctx.mp.println(msg)?;
    }
    batch_pb.finish_and_clear();

    batch_pb.println(format!(
        "{} {}",
        kind.done_arrow(),
        ctx.done_stats(kind, batch_stats, batch_timer.elapsed()),
    ));

    Ok(String::new())
}

/// # Errors
///
/// Will return `Err` if can not register Ctrl-C handler.
pub fn ctrlc_flag() -> anyhow::Result<Arc<AtomicBool>> {
    let flag = Arc::new(AtomicBool::new(false));
    let flag_clone = Arc::clone(&flag);
    let already_pressed = AtomicBool::new(false);
    ctrlc::set_handler(move || {
        if already_pressed.swap(true, Ordering::Relaxed) {
            log::warn!("{FAIL_MARK} Ctrl-C again, force exiting...");
            // Use _exit() to terminate immediately without running atexit handlers
            // or destructors, which can deadlock (e.g. indicatif's render thread).
            unsafe { libc::_exit(130) };
        }
        log::warn!(
            "{FAIL_MARK} Ctrl-C detected, finishing current file... (press again to force exit)"
        );
        flag_clone.store(true, Ordering::Relaxed);
    })?;

    Ok(flag)
}

fn bytes_progress_bar(size: u64, color: &str, moc: MoveOrCopy) -> indicatif::ProgressBar {
    let template = format!(
        "{{total_bytes:>11}} [{{bar:40.{color}/white}}] {{bytes:<11}} ({{bytes_per_sec:>13}}, ETA: {{eta_precise}} ) {{prefix}} {{msg}}"
    );
    let style = indicatif::ProgressStyle::with_template(&template)
        .unwrap()
        .progress_chars(moc.progress_chars());
    indicatif::ProgressBar::new(size).with_style(style)
}

fn item_progress_bar<Src: AsRef<Path>, Dest: AsRef<Path>>(
    size: u64,
    src: Src,
    dest: Dest,
    moc: MoveOrCopy,
) -> indicatif::ProgressBar {
    let color = if src.as_ref().is_dir() {
        "cyan"
    } else {
        "green"
    };
    bytes_progress_bar(size, color, moc).with_message(message_with_arrow(src, dest, moc))
}

fn source_size(src: &Path) -> u64 {
    if src.is_file() {
        std::fs::metadata(src).map(|m| m.len()).unwrap_or(0)
    } else {
        dir::collect_total_size(src)
    }
}

pub const FAIL_MARK: &str = "✗";

pub(crate) fn human_speed(bytes: u64, elapsed: std::time::Duration) -> String {
    let millis = elapsed.as_millis();
    if millis == 0 {
        return String::new();
    }
    let bps = u64::try_from(u128::from(bytes) * 1000 / millis).unwrap_or(u64::MAX);
    format!(" ({}/s)", indicatif::HumanBytes(bps))
}

fn message_with_arrow<Src: AsRef<Path>, Dest: AsRef<Path>>(
    src: Src,
    dest: Dest,
    moc: MoveOrCopy,
) -> String {
    format!(
        "{} {} {}",
        src.as_ref().display(),
        moc.arrow(),
        dest.as_ref().display()
    )
}

#[cfg(test)]
pub(crate) mod tests {
    use super::*;
    use std::fs;
    use std::path::{Path, PathBuf};
    use tempfile::tempdir;

    pub(crate) fn noop_ctrlc() -> Arc<AtomicBool> {
        Arc::new(AtomicBool::new(false))
    }

    pub(crate) fn hidden_multi_progress() -> indicatif::MultiProgress {
        indicatif::MultiProgress::with_draw_target(indicatif::ProgressDrawTarget::hidden())
    }

    pub(crate) fn create_temp_file<P: AsRef<Path>>(dir: P, name: &str, content: &str) -> PathBuf {
        let path = dir.as_ref().join(name);
        if let Some(parent) = path.parent() {
            fs::create_dir_all(parent).unwrap();
        }
        std::fs::write(&path, content).unwrap();
        path
    }

    pub(crate) fn assert_file_moved<Src: AsRef<Path>, Dest: AsRef<Path>>(
        src_path: Src,
        dest_path: Dest,
        expected_content: &str,
    ) {
        let src = src_path.as_ref();
        let dest = dest_path.as_ref();
        assert!(
            !src.exists(),
            "Source file still exists at {}",
            src.display()
        );
        assert!(
            dest.exists(),
            "Destination file does not exist at {}",
            dest.display()
        );
        let moved_content = fs::read_to_string(dest_path).unwrap();
        assert_eq!(
            moved_content, expected_content,
            "File content doesn't match after move"
        );
    }

    pub(crate) fn assert_file_not_moved<Src: AsRef<Path>, Dest: AsRef<Path>>(
        src_path: Src,
        dest_path: Dest,
    ) {
        let src = src_path.as_ref();
        let dest = dest_path.as_ref();
        assert!(
            src.exists(),
            "Source file does not exist at {}",
            src.display()
        );
        assert!(
            !dest.exists(),
            "Destination file should not exist at {}",
            dest.display()
        );
    }

    pub(crate) fn assert_file_copied<Src: AsRef<Path>, Dest: AsRef<Path>>(
        src_path: Src,
        dest_path: Dest,
    ) {
        let src = src_path.as_ref();
        let dest = dest_path.as_ref();
        assert!(
            src.exists(),
            "Source file does not exists at {}",
            src.display()
        );
        assert!(
            dest.exists(),
            "Destination file does not exist at {}",
            dest.display()
        );
        assert_eq!(
            fs::read_to_string(src).unwrap(),
            fs::read_to_string(dest_path).unwrap(),
            "File content doesn't match after copy"
        );
    }

    pub(crate) fn assert_error_with_msg(result: anyhow::Result<String>, msg: &str) {
        assert!(result.is_err(), "Expected an error, but got success");
        let err_msg = format!("{:#}", result.unwrap_err());
        assert!(
            err_msg.contains(msg),
            "Error message doesn't contain '{msg}': {err_msg}",
        );
    }

    fn _run_batch<Src: AsRef<Path>, Srcs: AsRef<[Src]>, Dest: AsRef<Path>>(
        srcs: Srcs,
        dest: Dest,
        moc: MoveOrCopy,
        force: bool,
    ) -> anyhow::Result<String> {
        let mp = hidden_multi_progress();
        let ctrlc = noop_ctrlc();
        let ctx = Ctx {
            moc,
            force,
            dry_run: false,
            batch_size: srcs.as_ref().len(),
            mp: &mp,
            ctrlc: &ctrlc,
        };
        run_batch(srcs, dest, &ctx)
    }

    #[test]
    fn move_file_to_new_dest() {
        let work_dir = tempdir().unwrap();
        let src_content = "This is a test file";
        let src_path = create_temp_file(work_dir.path(), "a", src_content);
        let dest_path = work_dir.path().join("b");

        _run_batch([&src_path], &dest_path, MoveOrCopy::Move, false).unwrap();
        assert_file_moved(&src_path, &dest_path, src_content);
    }

    #[test]
    fn move_multiple_files_to_directory() {
        let work_dir = tempdir().unwrap();
        let src_content = "This is a test file";
        let src_paths = vec![
            create_temp_file(work_dir.path(), "a", src_content),
            create_temp_file(work_dir.path(), "b", src_content),
        ];
        let dest_dir = work_dir.path().join("dest");
        fs::create_dir_all(&dest_dir).unwrap();

        _run_batch(&src_paths, &dest_dir, MoveOrCopy::Move, false).unwrap();
        for src_path in src_paths {
            let dest_path = dest_dir.join(src_path.file_name().unwrap());
            assert_file_moved(&src_path, &dest_path, src_content);
        }
    }

    #[test]
    fn move_multiple_files_fails_when_dest_does_not_exist_without_trailing_slash() {
        let work_dir = tempdir().unwrap();
        let src_content = "This is a test file";
        let src_paths = vec![
            create_temp_file(work_dir.path(), "a", src_content),
            create_temp_file(work_dir.path(), "b", src_content),
        ];
        let dest_dir = work_dir.path().join("dest");

        assert_error_with_msg(
            _run_batch(&src_paths, &dest_dir, MoveOrCopy::Move, false),
            "destination must be a directory or end with '/'",
        );
        for src_path in src_paths {
            let dest_path = dest_dir.join(src_path.file_name().unwrap());
            assert_file_not_moved(&src_path, &dest_path);
        }
    }

    #[test]
    fn move_multiple_files_creates_dest_with_trailing_slash() {
        let work_dir = tempdir().unwrap();
        let src_content = "This is a test file";
        let src_paths = vec![
            create_temp_file(work_dir.path(), "a", src_content),
            create_temp_file(work_dir.path(), "b", src_content),
        ];
        let dest_dir = work_dir.path().join("dest/");

        _run_batch(&src_paths, &dest_dir, MoveOrCopy::Move, false).unwrap();
        for src_path in &src_paths {
            let dest_path = dest_dir.join(src_path.file_name().unwrap());
            assert_file_moved(src_path, &dest_path, src_content);
        }
    }

    #[test]
    fn move_multiple_dirs_creates_dest_when_it_does_not_exist() {
        let work_dir = tempdir().unwrap();
        let src_dirs: Vec<_> = (0..3)
            .map(|i| {
                let d = tempdir().unwrap();
                create_temp_file(d.path(), &format!("file{i}"), &format!("content{i}"));
                d
            })
            .collect();
        let dest_dir = work_dir.path().join("dest");

        _run_batch(&src_dirs, &dest_dir, MoveOrCopy::Move, false).unwrap();
        for (i, src_dir) in src_dirs.iter().enumerate() {
            let src_path = src_dir.path().join(format!("file{i}"));
            let dest_path = dest_dir.join(format!("file{i}"));
            assert_file_moved(&src_path, &dest_path, &format!("content{i}"));
        }
    }

    #[test]
    fn move_mix_of_files_and_directories_fails() {
        let work_dir = tempdir().unwrap();
        let src_dir = tempdir().unwrap();
        let src_paths = vec![
            create_temp_file(work_dir.path(), "a", "This is a test file"),
            src_dir.path().to_path_buf(),
        ];
        let dest_dir = work_dir.path().join("dest");
        fs::create_dir_all(&dest_dir).unwrap();

        assert_error_with_msg(
            _run_batch(&src_paths, &dest_dir, MoveOrCopy::Move, false),
            "When there are multiple sources, they must be all files or all directories.",
        );
    }

    #[test]
    fn copy_file_basic() {
        let work_dir = tempdir().unwrap();
        let src_content = "This is a test file";
        let src_path = create_temp_file(work_dir.path(), "a", src_content);
        let dest_path = work_dir.path().join("b");

        _run_batch([&src_path], &dest_path, MoveOrCopy::Copy, false).unwrap();
        assert_file_copied(&src_path, &dest_path);
    }

    #[test]
    fn move_file_into_directory_with_trailing_slash() {
        let work_dir = tempdir().unwrap();
        let src_content = "This is a test file";
        let src_name = "a";
        let src_path = create_temp_file(&work_dir, src_name, src_content);
        let dest_dir = work_dir.path().join("b/c/");

        _run_batch([&src_path], &dest_dir, MoveOrCopy::Move, false).unwrap();
        assert_file_moved(src_path, dest_dir.join(src_name), src_content);
    }

    #[test]
    fn copy_file_into_directory_with_trailing_slash() {
        let work_dir = tempdir().unwrap();
        let src_content = "This is a test file";
        let src_name = "a";
        let src_path = create_temp_file(&work_dir, src_name, src_content);
        let dest_dir = work_dir.path().join("b/c/");

        _run_batch([&src_path], &dest_dir, MoveOrCopy::Copy, false).unwrap();
        assert_file_copied(src_path, dest_dir.join(src_name));
    }

    #[test]
    fn merge_directory_into_empty_dest() {
        let src_dir = tempdir().unwrap();
        let src_rel_paths = [
            "file1",
            "file2",
            "subdir/subfile1",
            "subdir/subfile2",
            "subdir/nested/nested_file",
        ];
        for path in src_rel_paths {
            create_temp_file(src_dir.path(), path, &format!("From source: {path}"));
        }

        let dest_dir = tempdir().unwrap();
        _run_batch([&src_dir], &dest_dir, MoveOrCopy::Move, false).unwrap();
        for path in src_rel_paths {
            let src_path = src_dir.path().join(path);
            let dest_path = dest_dir.path().join(path);
            assert_file_moved(&src_path, &dest_path, &format!("From source: {path}"));
        }
    }

    #[test]
    fn merge_multiple_directories_into_dest() {
        let src_num = 5;
        let src_dirs = (0..src_num)
            .filter_map(|_| tempdir().ok())
            .collect::<Vec<tempfile::TempDir>>();
        let src_rel_paths = (0..src_num)
            .map(|i| format! {"nested{i}/file{i}"})
            .collect::<Vec<String>>();
        (0..src_num).for_each(|i| {
            create_temp_file(&src_dirs[i], &src_rel_paths[i], &format!("content{i}"));
        });

        let dest_dir = tempdir().unwrap();
        _run_batch(&src_dirs, &dest_dir, MoveOrCopy::Move, false).unwrap();
        (0..src_num).for_each(|i| {
            let src_path = src_dirs[i].path().join(&src_rel_paths[i]);
            let dest_path = dest_dir.path().join(&src_rel_paths[i]);
            assert_file_moved(&src_path, &dest_path, &format!("content{i}"));
        });
    }

    #[test]
    fn dry_run_does_not_modify_files() {
        let work_dir = tempdir().unwrap();
        let src_content = "This is a test file";
        let src_path = create_temp_file(work_dir.path(), "a", src_content);
        let dest_path = work_dir.path().join("b");

        let mp = hidden_multi_progress();
        let ctrlc = noop_ctrlc();
        let ctx = Ctx {
            moc: MoveOrCopy::Move,
            force: false,
            dry_run: true,
            batch_size: 1,
            mp: &mp,
            ctrlc: &ctrlc,
        };
        run_batch([&src_path], &dest_path, &ctx).unwrap();

        assert!(
            src_path.exists(),
            "Source should still exist in dry-run mode"
        );
        assert!(
            !dest_path.exists(),
            "Dest should not be created in dry-run mode"
        );
    }

    #[test]
    fn fails_with_nonexistent_source() {
        let work_dir = tempdir().unwrap();
        let src_path = work_dir.path().join("nonexistent");
        let dest_path = work_dir.path().join("dest");

        assert_error_with_msg(
            _run_batch([&src_path], &dest_path, MoveOrCopy::Move, false),
            "neither a file nor directory",
        );
    }

    #[test]
    fn copy_multiple_files_to_directory() {
        let work_dir = tempdir().unwrap();
        let src_paths = vec![
            create_temp_file(work_dir.path(), "a", "content_a"),
            create_temp_file(work_dir.path(), "b", "content_b"),
        ];
        let dest_dir = work_dir.path().join("dest");
        fs::create_dir_all(&dest_dir).unwrap();

        _run_batch(&src_paths, &dest_dir, MoveOrCopy::Copy, false).unwrap();
        for src_path in &src_paths {
            let dest_path = dest_dir.join(src_path.file_name().unwrap());
            assert_file_copied(src_path, &dest_path);
        }
    }

    #[test]
    fn copy_directory_into_empty_dest() {
        let src_dir = tempdir().unwrap();
        let src_rel_paths = [
            "file1",
            "file2",
            "subdir/subfile1",
            "subdir/subfile2",
            "subdir/nested/nested_file",
        ];
        for path in src_rel_paths {
            create_temp_file(src_dir.path(), path, &format!("From source: {path}"));
        }

        let dest_dir = tempdir().unwrap();
        _run_batch([&src_dir], &dest_dir, MoveOrCopy::Copy, false).unwrap();
        for path in src_rel_paths {
            let src_path = src_dir.path().join(path);
            let dest_path = dest_dir.path().join(path);
            assert_file_copied(&src_path, &dest_path);
        }
    }
}