rustploy 0.1.11

Rustploy PaaS daemon — lightweight self-hosted deployment platform
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

//! Tudo que o updater pede ao sistema (rodar comando, esperar) passa por aqui, para
//! os testes trocarem o `dpkg` e o `systemctl` por um dublê.

use std::{io, process::Command, process::Stdio, time::Duration};

#[derive(Debug, Clone, Default)]
pub struct CommandOutput {
    pub success: bool,
    pub stdout: String,
    pub stderr: String,
}

pub trait System {
    /// Roda `program` com `args`, num ambiente limpo (só `PATH`, `LANG` e `envs`).
    /// Sem shell: cada argumento chega ao programa exatamente como está.
    fn run(&self, program: &str, args: &[&str], envs: &[(&str, &str)])
    -> io::Result<CommandOutput>;

    fn sleep(&self, duration: Duration);
}

pub struct RealSystem;

impl System for RealSystem {
    fn run(
        &self,
        program: &str,
        args: &[&str],
        envs: &[(&str, &str)],
    ) -> io::Result<CommandOutput> {
        let output = Command::new(program)
            .args(args)
            .env_clear()
            .env(
                "PATH",
                "/usr/local/sbin:/usr/local/bin:/usr/sbin:/usr/bin:/sbin:/bin",
            )
            .env("LANG", "C")
            .envs(envs.iter().copied())
            .stdin(Stdio::null())
            .output()?;
        Ok(CommandOutput {
            success: output.status.success(),
            stdout: String::from_utf8_lossy(&output.stdout).into_owned(),
            stderr: String::from_utf8_lossy(&output.stderr).into_owned(),
        })
    }

    fn sleep(&self, duration: Duration) {
        std::thread::sleep(duration);
    }
}