mod common;
use common::*;
use log::LevelFilter;
use xvc_core::{
    util::xvcignore::{walk_parallel, walk_serial, COMMON_IGNORE_PATTERNS},
    XvcPath,
};
use xvc_test_helper::test_logging;

use std::{collections::HashSet, path::Path, time::Duration};

use xvc_logging::watch;

use xvc::error::Result;

#[test]
fn test_walk() -> Result<()> {
    test_logging(LevelFilter::Trace);
    let (output_sender, output_receiver) = crossbeam_channel::unbounded();
    let xvc_root = run_in_example_xvc(true)?;
    watch!(xvc_root);

    let (pmp1, _) = walk_serial(&output_sender, &xvc_root, true)?;

    let path_set1 = HashSet::<XvcPath>::from_iter(pmp1.keys().cloned());
    assert!(!path_set1.is_empty());

    // Test skip list
    for skipped in [".dvc", ".xvc", ".git"] {
        let xp = XvcPath::new(&xvc_root, xvc_root.absolute_path(), Path::new(skipped))?;
        assert!(!path_set1.contains(&xp), "Result Contains {:?}", xp)
    }

    let (pmp2, _) = walk_parallel(&xvc_root, COMMON_IGNORE_PATTERNS, true)?;
    let path_set2 = HashSet::<XvcPath>::from_iter(pmp2.keys().cloned());
    assert!(!path_set2.is_empty());

    let diff1: HashSet<&XvcPath> = path_set1.difference(&path_set2).collect();
    watch!(diff1);

    let diff2: HashSet<&XvcPath> = path_set2.difference(&path_set1).collect();

    watch!(diff2);

    assert!(diff1.is_empty());
    assert!(diff2.is_empty());

    let mut output_lines = Vec::<String>::new();
    watch!(output_lines);
    while let Ok(Some(l)) = output_receiver.recv_timeout(Duration::from_secs(1)) {
        output_lines.push(l.to_string());
    }

    let output = output_lines.into_iter().collect::<Vec<String>>().join("\n");
    watch!(output);

    for (p, m) in pmp1 {
        assert!(pmp2[&p] == m)
    }

    clean_up(&xvc_root)
}