nuclei 0.5.2

Proactive IO & runtime system
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

//! Syncing a directory: the call, the answers for paths that are not
//! directories, and the atomic replace of a file.

use super::*;
use crate::fs::{rename, sync_dir};

#[test]
fn a_directory_syncs() {
    let rt = runtime();
    let tmp = Temp::new("dir-sync");
    std::fs::write(tmp.file("entry"), b"a name in the directory").unwrap();
    rt.block_on(async {
        within(sync_dir(&tmp.0)).await.unwrap();
        within(sync_dir(tmp.0.to_str().unwrap())).await.unwrap();
        within(sync_dir(tmp.0.clone())).await.unwrap();
    });
}

#[test]
fn a_path_that_is_missing_is_not_found_as_open_says() {
    let rt = runtime();
    let tmp = Temp::new("dir-missing");
    let missing = tmp.file("nothing");
    let theirs = File::open(&missing).unwrap_err();
    rt.block_on(async {
        let err = within(sync_dir(&missing)).await.unwrap_err();
        assert_eq!(err.kind(), io::ErrorKind::NotFound);
        assert_eq!(err.raw_os_error(), theirs.raw_os_error());
    });
}

#[cfg(unix)]
#[test]
fn a_path_that_is_not_a_directory_gets_the_systems_answer() {
    let rt = runtime();
    let tmp = Temp::new("dir-file");
    let path = tmp.file("plain");
    std::fs::write(&path, b"not a directory").unwrap();
    let theirs = File::open(&path).and_then(|file| file.sync_all());
    rt.block_on(async {
        let ours = within(sync_dir(&path)).await;
        assert_eq!(ours.is_ok(), theirs.is_ok());
        if let (Err(ours), Err(theirs)) = (ours, theirs) {
            assert_eq!(ours.raw_os_error(), theirs.raw_os_error());
        }
    });
}

#[test]
fn a_file_is_replaced_atomically_by_the_recipe() {
    let rt = runtime();
    let tmp = Temp::new("dir-replace");
    let target = tmp.file("target");
    std::fs::write(&target, b"old contents").unwrap();
    rt.block_on(async {
        let temporary = tmp.file("target.tmp");
        let mut file = within(Handle::<File>::create(&temporary)).await.unwrap();
        within(write_all(&mut file, b"new contents")).await.unwrap();
        within(file.sync_all()).await.unwrap();
        drop(file);
        within(rename(&temporary, &target)).await.unwrap();
        within(sync_dir(&tmp.0)).await.unwrap();
    });
    assert_eq!(std::fs::read(&target).unwrap(), b"new contents");
    assert!(!tmp.file("target.tmp").exists());
}