kftray-commons 0.27.33

KFtray commons
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

#[derive(serde::Serialize, serde::Deserialize, Debug)]

pub struct CustomResponse {
    pub id: Option<i64>,
    pub service: String,
    pub namespace: String,
    pub local_port: u16,
    pub remote_port: u16,
    pub context: String,
    pub stdout: String,
    pub stderr: String,
    pub status: i32,
    pub protocol: String,
}

impl CustomResponse {
    pub fn failed(&self) -> bool {
        self.status != 0
    }
}

/// Collapses a batch of per-configuration responses into a single error.
///
/// The start and stop batch commands report one result per configuration, so an
/// all-failed batch still returns `Ok`; every consumer has to inspect the
/// statuses rather than the outer result.
pub fn batch_failure(responses: &[CustomResponse]) -> Result<(), String> {
    let failures: Vec<String> = responses
        .iter()
        .filter(|response| response.failed())
        .map(|response| {
            if response.stderr.trim().is_empty() {
                match response.id {
                    Some(id) => format!("config {id} failed with no error message"),
                    None => "a configuration failed with no error message".to_owned(),
                }
            } else {
                response.stderr.clone()
            }
        })
        .collect();
    if failures.is_empty() {
        Ok(())
    } else {
        Err(failures.join("; "))
    }
}