pistonite-cu 0.8.3

Battery-included common utils to speed up development of rust tools
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
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138

use cu::pre::*;
use pistonite_cu as cu;

#[cu::cli]
async fn main(_: cu::cli::Flags) -> cu::Result<()> {
    cu::info!("color test!");
    cu::which("eza")?
        .command()
        .stdoe(cu::lv::P)
        .stdin_null()
        .co_wait()
        .await?;
    cu::which("eza")?
        .command()
        .add(cu::color_flag_eq())
        .add(cu::width_flag_eq())
        .stdoe(cu::lv::P)
        .stdin_null()
        .co_wait()
        .await?;

    // spinner
    let cleanup = if cu::yesno!("run git test?")? {
        cu::info!("git test!");
        let child = cu::which("git")?
            .command()
            .args(["clone", "https://github.com/zeldaret/botw", "--progress"])
            .stdoe(cu::pio::spinner("cloning botw"))
            .stdin_null()
            .co_spawn()
            .await?
            .0;
        let child2 = cu::which("git")?
            .command()
            .args([
                "clone",
                "https://github.com/rust-lang/rust",
                "--progress",
                "--depth",
                "1",
            ])
            .stdoe(cu::pio::spinner("cloning rust").info())
            .stdin_null()
            .co_spawn()
            .await?
            .0;
        child.co_wait_nz().await?;
        child2.co_wait_nz().await?;
        cu::info!("done");
        cu::hint!("cleaning stuff up since you know i don't want to manually delete it");
        std::fs::remove_dir_all("rust")?;
        let handle1 = cu::co::spawn(async move {
            cu::fs::co_rec_remove("botw").await?;
            cu::Ok(())
        });
        let handle2 = cu::co::spawn(async move {
            cu::fs::co_rec_remove("rust").await?;
            cu::Ok(())
        });
        Some(cu::co::spawn(async move {
            handle1.co_join().await??;
            handle2.co_join().await??;
            cu::Ok(())
        }))
    } else {
        None
    };

    // pipes, co
    let (hello, out) = cu::which("echo")?
        .command()
        .arg("Hello, world!")
        .stdout(cu::pio::pipe())
        .stdie_null()
        .co_spawn()
        .await?;
    hello.co_wait_nz().await?;

    cu::which("rev")?
        .command()
        .stdin(out)
        .stdoe(cu::lv::I)
        .name("rev")
        .co_wait_nz()
        .await?;

    // blocking line stream
    let (child, lines) = cu::which("bash")?
        .command()
        .args(["-c", r#"for i in {1..5}; do echo "Line $i"; sleep 1; done"#])
        .stdout(cu::pio::lines())
        .stdie_null()
        .co_spawn()
        .await?;
    // read the lines
    for line in lines {
        cu::info!("{line:?}");
    }
    child.co_wait_nz().await?;

    // async line stream
    let (child2, lines2) = cu::which("bash")?
        .command()
        .args(["-c", r#"for i in {1..5}; do echo "Line $i"; sleep 1; done"#])
        .stdout(cu::pio::co_lines())
        .stdie_null()
        .co_spawn()
        .await?;
    // wait and read the lines
    let mut lines2 = lines2;
    while let Some(line) = lines2.next().await {
        let line = line?;
        cu::info!("{line:?}");
    }
    child2.co_wait_nz().await?;

    // capture
    let (hello, out) = cu::which("cat")?
        .command()
        .arg("Cargo.toml")
        .stdout(cu::pio::string())
        .stdie_null()
        .co_spawn()
        .await?;

    let x = out.co_join().await?;
    cu::info!("capture output: {x:?}");
    let x = x?;
    // let x=String::from_utf8(x)?;
    cu::info!("decoded: {x}");
    hello.co_wait_nz().await?;

    if let Some(cleanup) = cleanup {
        cleanup.co_join().await??
    }

    Ok(())
}