From 989c71059ed7ddd54c5dc28d13927b5b4d2f22a3 Mon Sep 17 00:00:00 2001
From: Daniel Sockwell <dsockwell@gmail.com>
Date: Mon, 9 Sep 2019 14:23:48 -0400
Subject: [PATCH] Remove debug statements (#43)

---
 src/main.rs                       |  6 ++----
 src/parse_client_request/sse.rs   | 12 +++++-------
 src/redis_to_client_stream/mod.rs |  1 -
 3 files changed, 7 insertions(+), 12 deletions(-)

diff --git a/src/main.rs b/src/main.rs
index 05e3e15..79e73ba 100644
--- a/src/main.rs
+++ b/src/main.rs
@@ -4,7 +4,7 @@ use flodgatt::{
     redis_to_client_stream,
     redis_to_client_stream::ClientAgent,
 };
-use log::{log_enabled, Level};
+use log::warn;
 use warp::{ws::Ws2, Filter as WarpFilter};
 
 fn main() {
@@ -12,9 +12,7 @@ fn main() {
     let client_agent_sse = ClientAgent::blank();
     let client_agent_ws = client_agent_sse.clone_with_shared_receiver();
 
-    if log_enabled!(Level::Warn) {
-        println!("Streaming server initialized and ready to accept connections");
-    };
+    warn!("Streaming server initialized and ready to accept connections");
 
     // Server Sent Events
     let sse_routes = sse::extract_user_or_reject()
diff --git a/src/parse_client_request/sse.rs b/src/parse_client_request/sse.rs
index cf3df0f..4005b4d 100644
--- a/src/parse_client_request/sse.rs
+++ b/src/parse_client_request/sse.rs
@@ -123,11 +123,10 @@ mod test {
             fn $name() {
                 let  path = format!("{}?access_token=INVALID", $path);
                 $(let path = format!("{}&{}", path, $query);)*
-                    dbg!(&path);
-                    warp::test::request()
-                        .path(&path)
-                        .filter(&extract_user_or_reject())
-                        .expect("in test");
+                warp::test::request()
+                    .path(&path)
+                    .filter(&extract_user_or_reject())
+                    .expect("in test");
             }
         };
     }
@@ -141,8 +140,7 @@ mod test {
             fn $name() {
                 let path = $path;
                 $(let path = format!("{}?{}", path, $query);)*
-                    dbg!(&path);
-                    warp::test::request()
+                warp::test::request()
                     .path(&path)
                     .header("Authorization", "Bearer: INVALID")
                     .filter(&extract_user_or_reject())
diff --git a/src/redis_to_client_stream/mod.rs b/src/redis_to_client_stream/mod.rs
index a9221a3..b74c372 100644
--- a/src/redis_to_client_stream/mod.rs
+++ b/src/redis_to_client_stream/mod.rs
@@ -63,7 +63,6 @@ pub fn send_updates_to_ws(
         .for_each(move |_json_value| {
             if let Ok(Async::Ready(Some(json_value))) = stream.poll() {
                 let msg = warp::ws::Message::text(json_value.to_string());
-                //                dbg!(&msg);
                 tx.unbounded_send(msg).expect("No send error");
             };
             Ok(())