parawalk 0.1.4

Blazing-fast parallel directory walker with zero filtering baggage
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100

use std::path::PathBuf;
use std::sync::{Arc, Mutex};

use parawalk::{Entry, WalkConfig, walk};

#[test]
fn walks_tmp_dir() {
    // Create a small temp tree
    let tmp = std::env::temp_dir().join("parawalk_test");
    std::fs::create_dir_all(&tmp).unwrap();
    std::fs::write(tmp.join("a.txt"), "a").unwrap();
    std::fs::write(tmp.join("b.txt"), "b").unwrap();
    let sub = tmp.join("sub");
    std::fs::create_dir_all(&sub).unwrap();
    std::fs::write(sub.join("c.txt"), "c").unwrap();

    let results: Arc<Mutex<Vec<Entry>>> = Arc::new(Mutex::new(Vec::new()));
    let results_clone = Arc::clone(&results);

    walk(
        tmp.clone(),
        WalkConfig::default(),
        None::<fn(&parawalk::EntryRef<'_>) -> bool>,
        move || {
            let r = Arc::clone(&results_clone);
            move |entry| {
                r.lock().unwrap().push(entry);
            }
        },
    );

    let found = results.lock().unwrap();
    assert_eq!(found.len(), 4); // a.txt, b.txt, sub/, sub/c.txt

    // Cleanup
    std::fs::remove_dir_all(&tmp).ok();
}

#[test]
fn pre_filter_skips_non_matching() {
    let tmp = std::env::temp_dir().join("parawalk_filter_test");
    std::fs::create_dir_all(&tmp).unwrap();
    std::fs::write(tmp.join("invoice.txt"), "").unwrap();
    std::fs::write(tmp.join("report.txt"), "").unwrap();
    std::fs::write(tmp.join("invoice_feb.txt"), "").unwrap();

    let results: Arc<Mutex<Vec<PathBuf>>> = Arc::new(Mutex::new(Vec::new()));
    let results_clone = Arc::clone(&results);

    walk(
        tmp.clone(),
        WalkConfig::default(),
        Some(|entry: &parawalk::EntryRef<'_>| entry.name.to_string_lossy().contains("invoice")),
        move || {
            let r = Arc::clone(&results_clone);
            move |entry: parawalk::Entry| {
                r.lock().unwrap().push(entry.path);
            }
        },
    );

    let found = results.lock().unwrap();
    assert_eq!(found.len(), 2);

    std::fs::remove_dir_all(&tmp).ok();
}

#[test]
fn respects_max_depth() {
    let tmp = std::env::temp_dir().join("parawalk_depth_test");
    std::fs::create_dir_all(&tmp).unwrap();
    std::fs::write(tmp.join("root.txt"), "").unwrap();
    let sub = tmp.join("sub");
    std::fs::create_dir_all(&sub).unwrap();
    std::fs::write(sub.join("deep.txt"), "").unwrap();

    let results: Arc<Mutex<Vec<Entry>>> = Arc::new(Mutex::new(Vec::new()));
    let results_clone = Arc::clone(&results);

    walk(
        tmp.clone(),
        WalkConfig {
            max_depth: Some(1),
            ..WalkConfig::default()
        },
        None::<fn(&parawalk::EntryRef<'_>) -> bool>,
        move || {
            let r = Arc::clone(&results_clone);
            move |entry| {
                r.lock().unwrap().push(entry);
            }
        },
    );

    let found = results.lock().unwrap();
    // depth 1 = root.txt + sub/ only, not sub/deep.txt
    assert_eq!(found.len(), 2);

    std::fs::remove_dir_all(&tmp).ok();
}