sdml-generate 0.3.2

Simple Domain Modeling Language (SDML) generated Artifacts
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

use std::{
    io::{self, ErrorKind, Write},
    path::Path,
    process::{Command, Output},
};
use tempfile::NamedTempFile;
use tracing::error;

// ------------------------------------------------------------------------------------------------
// Public Types
// ------------------------------------------------------------------------------------------------

#[derive(Clone, Debug)]
pub(crate) struct CommandArg {
    option: Option<String>,
    value: String,
}

// ------------------------------------------------------------------------------------------------
// Public Functions
// ------------------------------------------------------------------------------------------------

pub(crate) fn exec_with_temp_input<S1, S2>(
    program: S1,
    args: Vec<CommandArg>,
    temp_file_contents: S2,
) -> io::Result<String>
where
    S1: Into<String> + std::fmt::Debug,
    S2: Into<String>,
{
    trace_entry!("exec_with_input" => "{:?}, {:?}, ...", program, args);
    write_to_temp_file(temp_file_contents.into()).and_then(|f| {
        let mut args_mut = args;
        args_mut.push(CommandArg::from_path(f.path()));
        exec(program, args_mut)
    })
}

pub(crate) fn exec<S>(program: S, args: Vec<CommandArg>) -> io::Result<String>
where
    S: Into<String> + std::fmt::Debug,
{
    trace_entry!("exec" => "{:?}, {:?}", program, args);
    let args = args.into_iter().flat_map(|a| a.into_args()).collect();
    exec_inner(program, args).and_then(|o| {
        if o.status.code().map(|c| c != 0).unwrap_or(true) {
            error!("command execution failed; error: {:?}", o.status);
            let mes = String::from_utf8_lossy(&o.stderr).to_string();
            Err(std::io::Error::new(ErrorKind::Other, mes))
        } else {
            Ok(String::from_utf8_lossy(&o.stdout).to_string())
        }
    })
}

#[inline(always)]
fn exec_inner<S>(executable: S, args: Vec<String>) -> io::Result<Output>
where
    S: Into<String>,
{
    Command::new(executable.into()).args(args).output()
}

#[inline(always)]
fn write_to_temp_file(content: String) -> io::Result<NamedTempFile> {
    let mut file = NamedTempFile::new()?;
    file.write_all(content.as_bytes()).map(|_| file)
}

// ------------------------------------------------------------------------------------------------
// Implementations
// ------------------------------------------------------------------------------------------------

impl CommandArg {
    pub(crate) fn new<S>(value: S) -> Self
    where
        S: Into<String>,
    {
        Self {
            option: None,
            value: value.into(),
        }
    }

    pub(crate) fn new_option<S1, S2>(option: S1, value: S2) -> Self
    where
        S1: Into<String>,
        S2: Into<String>,
    {
        Self {
            option: Some(option.into()),
            value: value.into(),
        }
    }

    pub(crate) fn from_path<P>(path: P) -> Self
    where
        P: AsRef<Path>,
    {
        Self::new(path.as_ref().to_string_lossy().to_string())
    }

    pub(crate) fn into_args(self) -> Vec<String> {
        if let Some(option) = self.option {
            vec![option, self.value]
        } else {
            vec![self.value]
        }
    }

    #[allow(dead_code)]
    pub(crate) fn into_single(self) -> Self {
        if let Some(option) = self.option {
            Self::new(format!("{} {}", option, self.value))
        } else {
            self
        }
    }
}