From e8744b23c510f2390f48056ca7fef3425ee2ff0f Mon Sep 17 00:00:00 2001 From: asonix Date: Thu, 19 Mar 2020 20:11:50 -0500 Subject: [PATCH] Update debug levels --- Cargo.lock | 4 ++-- Cargo.toml | 2 +- src/notify.rs | 13 ++++++------- 3 files changed, 9 insertions(+), 10 deletions(-) diff --git a/Cargo.lock b/Cargo.lock index eb8043e..cdfcf53 100644 --- a/Cargo.lock +++ b/Cargo.lock @@ -1122,9 +1122,9 @@ dependencies = [ [[package]] name = "http-signature-normalization-actix" -version = "0.3.0-alpha.5" +version = "0.3.0-alpha.6" source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "2ef97fd4d560efcc886defdd46b44ac9dbaa6000c467bf0a6a63592a5373a468" +checksum = "da5b8165a06ced6083c67a62538a48a0d7e952d66c35f6bd0da2f6c35a4689ff" dependencies = [ "actix-http", "actix-web", diff --git a/Cargo.toml b/Cargo.toml index 25c1bbf..2f54b66 100644 --- a/Cargo.toml +++ b/Cargo.toml @@ -18,7 +18,7 @@ bb8-postgres = "0.4.0" config = "0.10.1" dotenv = "0.15.0" futures = "0.3.4" -http-signature-normalization-actix = { version = "0.3.0-alpha.5", default-features = false, features = ["sha-2"] } +http-signature-normalization-actix = { version = "0.3.0-alpha.6", default-features = false, features = ["sha-2"] } log = "0.4" lru = "0.4.3" num_cpus = "1.12" diff --git a/src/notify.rs b/src/notify.rs index c6d1b4b..c3c6086 100644 --- a/src/notify.rs +++ b/src/notify.rs @@ -119,34 +119,33 @@ impl StreamHandler for NotifyHandler { fn handle(&mut self, Notify(notif): Notify, ctx: &mut Self::Context) { let state = self.state.clone(); - info!("Handling notification in {}", notif.channel()); let fut = async move { match notif.channel() { "new_blocks" => { - debug!("Caching block of {}", notif.payload()); + info!("Caching block of {}", notif.payload()); state.cache_block(notif.payload().to_owned()).await; } "new_whitelists" => { - debug!("Caching whitelist of {}", notif.payload()); + info!("Caching whitelist of {}", notif.payload()); state.cache_whitelist(notif.payload().to_owned()).await; } "new_listeners" => { if let Ok(uri) = notif.payload().parse::() { - debug!("Caching listener {}", uri); + info!("Caching listener {}", uri); state.cache_listener(uri).await; } } "rm_blocks" => { - debug!("Busting block cache for {}", notif.payload()); + info!("Busting block cache for {}", notif.payload()); state.bust_block(notif.payload()).await; } "rm_whitelists" => { - debug!("Busting whitelist cache for {}", notif.payload()); + info!("Busting whitelist cache for {}", notif.payload()); state.bust_whitelist(notif.payload()).await; } "rm_listeners" => { if let Ok(uri) = notif.payload().parse::() { - debug!("Busting listener cache for {}", uri); + info!("Busting listener cache for {}", uri); state.bust_listener(&uri).await; } }