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
use crate::error::SchedulerError;
use crate::schema::GenericResponse;
use juniper::GraphQLObject;
use log::{error, info};
use reqwest::Client;
use serde::{Deserialize, Serialize};
use serde_json::from_str;
use std::collections::HashMap;
use std::time::Duration;
#[derive(Debug, Deserialize)]
pub struct StartAppResponse {
#[serde(rename = "startApp")]
pub start_app: GenericResponse,
}
#[derive(Debug, Deserialize)]
pub struct StartAppGraphQL {
pub data: StartAppResponse,
}
pub fn service_query(query: &str, hosturl: &str) -> Result<StartAppGraphQL, SchedulerError> {
let client = Client::builder()
.timeout(Duration::from_millis(350))
.build()
.map_err(|e| SchedulerError::QueryError { err: e.to_string() })?;
let mut map = HashMap::new();
map.insert("query", query);
let url = format!("http://{}", hosturl);
let mut res = client
.post(&url)
.json(&map)
.send()
.map_err(|e| SchedulerError::QueryError { err: e.to_string() })?;
Ok(from_str(
&res.text()
.map_err(|e| SchedulerError::QueryError { err: e.to_string() })?,
)
.map_err(|e| SchedulerError::QueryError { err: e.to_string() })?)
}
#[derive(Clone, Debug, GraphQLObject, Serialize, Deserialize)]
pub struct App {
pub name: String,
pub args: Option<Vec<String>>,
pub config: Option<String>,
}
impl App {
pub fn execute(&self, service_url: &str) {
info!("Start app {}", self.name);
let mut query_args = format!("name: \"{}\"", self.name);
if let Some(config) = &self.config {
query_args.push_str(&format!(", config: \"{}\"", config));
}
if let Some(args) = &self.args {
let app_args: Vec<String> = args.iter().map(|x| format!("\"{}\"", x)).collect();
let app_args = app_args.join(",");
query_args.push_str(&format!(", args: [{}]", app_args));
}
let query = format!(
r#"mutation {{ startApp({}) {{ success, errors }} }}"#,
query_args
);
match service_query(&query, &service_url) {
Err(e) => {
error!("Failed to send start app query: {}", e);
}
Ok(resp) => {
if !resp.data.start_app.success {
error!(
"Failed to start scheduled app: {}",
resp.data.start_app.errors
);
}
}
}
}
}