mkutils 0.1.126

Utility methods, traits, and types.
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

use crate::utils::Utils;
use anyhow::{Context, Error as AnyhowError};
use derive_more::{Constructor, From, Into};
use std::{
    borrow::Borrow,
    ffi::OsStr,
    io::Error as IoError,
    path::Path,
    process::{ExitStatus, Stdio},
};
use tokio::process::{Child, ChildStderr, ChildStdin, ChildStdout, Command};

#[derive(From, Into)]
pub struct ProcessBuilder {
    command: Command,
}

impl ProcessBuilder {
    const STDIO_ERROR_MESSAGE: &str = "unable to set up stdio for process";

    pub fn new(cmd: impl AsRef<OsStr>) -> Self {
        let mut command = Command::new(cmd);

        command
            .stdin(Stdio::piped())
            .stdout(Stdio::piped())
            .stderr(Stdio::piped());

        command.into()
    }

    pub fn arg(&mut self, arg: impl AsRef<OsStr>) -> &mut Self {
        self.command.arg(arg);

        self
    }

    pub fn args(&mut self, args: impl IntoIterator<Item: AsRef<OsStr>>) -> &mut Self {
        self.command.args(args);

        self
    }

    pub fn env(&mut self, env: impl IntoIterator<Item: Borrow<(impl AsRef<OsStr>, impl AsRef<OsStr>)>>) -> &mut Self {
        for env_entry in env {
            let (env_var_name, env_var_val) = env_entry.borrow();

            self.command.env(env_var_name, env_var_val);
        }

        self
    }

    pub fn current_dirpath<P: AsRef<Path>>(&mut self, current_dirpath: impl Into<Option<P>>) -> &mut Self {
        if let Some(current_dirpath) = current_dirpath.into() {
            self.command.current_dir(current_dirpath);
        }

        self
    }

    fn take_stdio<T>(stdio: &mut Option<T>) -> Result<T, AnyhowError> {
        stdio.take().context(Self::STDIO_ERROR_MESSAGE)
    }

    pub const fn command_mut(&mut self) -> &mut Command {
        &mut self.command
    }

    pub fn build(&mut self) -> Result<Process, AnyhowError> {
        let mut child = self.command.spawn()?;
        let stdin = Self::take_stdio(&mut child.stdin)?;
        let stdout = Self::take_stdio(&mut child.stdout)?;
        let stderr = Self::take_stdio(&mut child.stderr)?;
        let process = Process::new(child, stdin, stdout, stderr);

        process.ok()
    }
}

#[derive(Constructor)]
pub struct Process {
    child: Child,
    stdin: ChildStdin,
    stdout: ChildStdout,
    stderr: ChildStderr,
}

impl Process {
    pub const fn stdin_mut(&mut self) -> &mut ChildStdin {
        &mut self.stdin
    }

    pub const fn stdout_mut(&mut self) -> &mut ChildStdout {
        &mut self.stdout
    }

    pub const fn stderr_mut(&mut self) -> &mut ChildStderr {
        &mut self.stderr
    }

    #[must_use]
    pub fn into_parts(self) -> (Child, ChildStdin, ChildStdout, ChildStderr) {
        (self.child, self.stdin, self.stdout, self.stderr)
    }

    pub async fn run(mut self) -> Result<ExitStatus, IoError> {
        self.stdin.mem_drop();
        self.stdout.mem_drop();
        self.stderr.mem_drop();
        self.child.wait().await?.ok()
    }
}