ComputerSurge/komodo
3
0
Fork 0
forked from github-starred/komodo
Code Pull Requests 1 Actions Packages Releases Activity

fix updates pagination

Browse Source
This commit is contained in:
mbecker20
2023-01-04 22:41:48 +00:00
parent f6f94303a5
commit ac3d17ce82
2 changed files with 10 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files
core/src/api/update.rs
+1 -1
View File
@@ -24,7 +24,7 @@ pub fn router() -> Router {
Query(value): Query<Value>| async move {
let offset = value
.get("offset")
.map(|v| v.as_u64().unwrap_or(0))
.map(|v| v.as_str().unwrap_or("0").parse().unwrap_or(0))
.unwrap_or(0);
let target = serde_json::from_str::<UpdateTarget>(&value.to_string()).ok();
let updates = state
core/src/monitoring.rs
+9 -6
View File
@@ -31,13 +31,16 @@ impl State {
}
for (server, res) in servers.unwrap() {
if let Err(e) = res {
println!("server unreachable: {e:?}");
if let Some(slack) = &self.slack {
let (header, info) = generate_unreachable_message(&server);
let res = slack.send_message_with_header(&header, info.clone()).await;
if let Err(e) = res {
eprintln!("failed to send message to slack: {e} | header: {header} | info: {info:?}")
if e.to_string().contains("error trying to connect") {
if let Some(slack) = &self.slack {
let (header, info) = generate_unreachable_message(&server);
let res = slack.send_message_with_header(&header, info.clone()).await;
if let Err(e) = res {
eprintln!("failed to send message to slack: {e} | header: {header} | info: {info:?}")
}
}
} else {
println!("failed to get stats from {}: {e:?}", server.name);
}
continue;
}