edward/mangadex-home-rs
1
0
Fork 0
Code Issues Pull requests Projects Releases Wiki Activity

Fix logging messages

Browse source
This commit is contained in:
Edward Shen 2021-05-27 16:22:15 -04:00
parent c32e534300
commit f038452263
Signed by: edward
GPG key ID: 19182661E818369F
3 changed files with 6 additions and 5 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

7
src/ping.rs
View file

@ -176,9 +176,10 @@ pub async fn update_server_state(secret: &str, cli: &CliArgs, data: &mut Arc<RwL
debug!("got write guard for server state"); debug!("got write guard for server state");
let mut write_guard = data.0.write(); let mut write_guard = data.0.write();
if !write_guard.url_overridden && write_guard.image_server != resp.image_server { let image_server_changed = write_guard.image_server != resp.image_server;
if !write_guard.url_overridden && image_server_changed {
write_guard.image_server = resp.image_server; write_guard.image_server = resp.image_server;
} else { } else if image_server_changed {
warn!("Ignoring new upstream url!"); warn!("Ignoring new upstream url!");
} }
@ -220,7 +221,7 @@ pub async fn update_server_state(secret: &str, cli: &CliArgs, data: &mut Arc<RwL
PREVIOUSLY_COMPROMISED.store(resp.compromised, Ordering::Release); PREVIOUSLY_COMPROMISED.store(resp.compromised, Ordering::Release);
if resp.compromised { if resp.compromised {
error!("Got compromised response from control center!"); error!("Got compromised response from control center!");
} else { } else if previously_compromised {
info!("No longer compromised!"); info!("No longer compromised!");
} }
} }

2
src/routes.rs
View file

@ -11,7 +11,7 @@ use actix_web::{get, web::Data, HttpRequest, HttpResponse, Responder};
use base64::DecodeError; use base64::DecodeError;
use bytes::Bytes; use bytes::Bytes;
use chrono::{DateTime, Utc}; use chrono::{DateTime, Utc};
use futures::{AsyncReadExt, Stream, TryStreamExt}; use futures::{Stream, TryStreamExt};
use log::{debug, error, info, warn}; use log::{debug, error, info, warn};
use once_cell::sync::Lazy; use once_cell::sync::Lazy;
use prometheus::{Encoder, TextEncoder}; use prometheus::{Encoder, TextEncoder};

2
src/state.rs
View file

@ -75,7 +75,7 @@ impl ServerState {
} }
})?; })?;
PREVIOUSLY_COMPROMISED.store(resp.paused, Ordering::Release); PREVIOUSLY_COMPROMISED.store(resp.compromised, Ordering::Release);
if resp.compromised { if resp.compromised {
error!("Got compromised response from control center!"); error!("Got compromised response from control center!");
} }