pipedash-plugin-komodo 0.9.0

Komodo plugin for Pipedash
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
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161

use serde::Deserialize;

#[derive(Debug, Deserialize)]
pub(crate) struct VersionResponse {
    #[serde(default)]
    pub version: String,
}

#[derive(Debug, Deserialize)]
pub(crate) struct StackListItem {
    pub id: String,
    pub name: String,
    #[serde(default)]
    pub template: bool,
    #[serde(default)]
    pub info: StackInfo,
}

#[derive(Debug, Default, Deserialize)]
pub(crate) struct StackInfo {
    #[serde(default)]
    pub server_id: String,
    #[serde(default)]
    pub server_name: String,
    #[serde(default)]
    pub swarm_name: String,
    #[serde(default)]
    pub repo: String,
    #[serde(default)]
    pub branch: String,
    #[serde(default)]
    pub repo_link: String,
    #[serde(default)]
    pub state: String,
    #[serde(default)]
    pub status: Option<String>,
    #[serde(default)]
    pub services: Vec<StackService>,
    #[serde(default)]
    pub project_missing: bool,
    #[serde(default)]
    pub missing_files: Vec<String>,
    #[serde(default)]
    pub deployed_hash: Option<String>,
    #[serde(default)]
    pub latest_hash: Option<String>,
}

impl StackInfo {
    pub fn host(&self) -> &str {
        [&self.server_name, &self.swarm_name, &self.server_id]
            .into_iter()
            .find(|name| !name.is_empty())
            .map_or("", String::as_str)
    }

    pub fn update_available(&self) -> bool {
        self.services.iter().any(|service| service.update_available)
    }
}

#[derive(Debug, Default, Deserialize)]
pub(crate) struct StackService {
    #[serde(default)]
    pub update_available: bool,
}

#[derive(Debug, Deserialize)]
pub(crate) struct ListUpdatesResponse {
    #[serde(default)]
    pub updates: Vec<UpdateListItem>,
    #[serde(default)]
    pub next_page: Option<u32>,
}

#[derive(Debug, Deserialize)]
pub(crate) struct UpdateListItem {
    #[serde(default)]
    pub id: String,
    #[serde(default)]
    pub operation: String,
    #[serde(default)]
    pub start_ts: i64,
    #[serde(default)]
    pub success: bool,
    #[serde(default)]
    pub username: String,
    #[serde(default)]
    pub operator: String,
    #[serde(default)]
    pub status: String,
    #[serde(default)]
    pub target: UpdateTarget,
}

#[derive(Debug, Default, Deserialize)]
pub(crate) struct UpdateTarget {
    #[serde(default)]
    pub id: String,
}

#[derive(Debug, Deserialize)]
#[serde(untagged)]
pub(crate) enum MongoId {
    Object {
        #[serde(rename = "$oid")]
        oid: String,
    },
    Plain(String),
}

impl MongoId {
    pub fn into_string(self) -> String {
        match self {
            Self::Object { oid } => oid,
            Self::Plain(id) => id,
        }
    }
}

#[derive(Debug, Deserialize)]
pub(crate) struct Update {
    #[serde(default, rename = "_id")]
    pub id: Option<MongoId>,
    #[serde(default)]
    pub start_ts: i64,
    #[serde(default)]
    pub end_ts: Option<i64>,
    #[serde(default)]
    pub success: bool,
    #[serde(default)]
    pub status: String,
    #[serde(default)]
    pub commit_hash: String,
}

#[derive(Debug, Deserialize)]
pub(crate) struct UpdateLogs {
    #[serde(default)]
    pub status: String,
    #[serde(default)]
    pub logs: Vec<UpdateLog>,
}

#[derive(Debug, Deserialize)]
pub(crate) struct UpdateLog {
    #[serde(default)]
    pub stage: String,
    #[serde(default)]
    pub command: String,
    #[serde(default)]
    pub stdout: String,
    #[serde(default)]
    pub stderr: String,
    #[serde(default)]
    pub success: bool,
    #[serde(default)]
    pub start_ts: i64,
    #[serde(default)]
    pub end_ts: i64,
}