]> Untitled Git - lemmy.git/commitdiff
Proper error logging for websocket
authorFelix Ableitner <me@nutomic.com>
Thu, 12 Mar 2020 11:03:04 +0000 (12:03 +0100)
committerFelix Ableitner <me@nutomic.com>
Thu, 12 Mar 2020 11:03:04 +0000 (12:03 +0100)
server/Cargo.lock
server/Cargo.toml
server/src/websocket/server.rs

index a39dcd6411be0f6ce653401bb572f05412ca03f7..a58e0438b589b2b081f685989a1baee046d957a5 100644 (file)
@@ -1448,6 +1448,7 @@ dependencies = [
  "lazy_static 1.4.0 (registry+https://github.com/rust-lang/crates.io-index)",
  "lettre 0.9.2 (registry+https://github.com/rust-lang/crates.io-index)",
  "lettre_email 0.9.2 (registry+https://github.com/rust-lang/crates.io-index)",
+ "log 0.4.8 (registry+https://github.com/rust-lang/crates.io-index)",
  "percent-encoding 2.1.0 (registry+https://github.com/rust-lang/crates.io-index)",
  "rand 0.7.3 (registry+https://github.com/rust-lang/crates.io-index)",
  "regex 1.3.4 (registry+https://github.com/rust-lang/crates.io-index)",
index e73143687fbf4f2963c7af62a5ef7ebfc8ef3447..10c0dfc8124d6b1140b36bd42339e76b60ea1735 100644 (file)
@@ -19,6 +19,7 @@ actix-web = "2.0.0"
 actix-files = "0.2.1"
 actix-web-actors = "2.0.0"
 actix-rt = "1.0.0"
+log = "0.4.0"
 env_logger = "0.7.1"
 rand = "0.7.3"
 strum = "0.17.1"
index 1cbcb34fb738ebd10e853d65a196fa10246b5e28..e200b1b99100880657dfcdafaf970d0cf69bf2f1 100644 (file)
@@ -6,6 +6,7 @@ use actix::prelude::*;
 use diesel::r2d2::{ConnectionManager, Pool, PooledConnection};
 use diesel::PgConnection;
 use failure::Error;
+use log::warn;
 use rand::{rngs::ThreadRng, Rng};
 use serde::{Deserialize, Serialize};
 use serde_json::Value;
@@ -448,13 +449,16 @@ impl Handler<StandardMessage> for ChatServer {
   type Result = MessageResult<StandardMessage>;
 
   fn handle(&mut self, msg: StandardMessage, _: &mut Context<Self>) -> Self::Result {
-    let msg_out = match parse_json_message(self, msg) {
-      Ok(m) => m,
-      Err(e) => e.to_string(),
-    };
-
-    println!("Message Sent: {}", msg_out);
-    MessageResult(msg_out)
+    match parse_json_message(self, msg) {
+      Ok(m) => {
+        println!("Message Sent: {}", m);
+        MessageResult(m)
+      }
+      Err(e) => {
+        warn!("Error during message handling {}", e);
+        MessageResult(e.to_string())
+      }
+    }
   }
 }