diff --git a/core.pkl b/core.pkl index 92c294a..628b69f 100644 --- a/core.pkl +++ b/core.pkl @@ -1 +1,5 @@ -amends "package://emgauwa.app/pkl/emgauwa@0.1.0#/core.pkl" +amends "package://emgauwa.app/pkl/emgauwa@0.1.1#/core.pkl" + +logging { + level = "DEBUG" +} diff --git a/src/handlers/v1/ws/controllers/mod.rs b/src/handlers/v1/ws/controllers/mod.rs index 2b39e5a..9e5c63f 100644 --- a/src/handlers/v1/ws/controllers/mod.rs +++ b/src/handlers/v1/ws/controllers/mod.rs @@ -78,6 +78,7 @@ impl ControllersWs { return; } + log::trace!("Sending ping to controller"); ctx.ping(&[]); }); } @@ -122,10 +123,12 @@ impl StreamHandler> for ControllersWs { match msg { Message::Ping(msg) => { + log::trace!("Received ping from controller: {:?}", msg); self.hb = Instant::now(); ctx.pong(&msg) } Message::Pong(_) => { + log::trace!("Received pong from controller"); self.hb = Instant::now(); } Message::Text(text) => match serde_json::from_str(&text) { diff --git a/src/handlers/v1/ws/relays/mod.rs b/src/handlers/v1/ws/relays/mod.rs index f4dd9e2..106053d 100644 --- a/src/handlers/v1/ws/relays/mod.rs +++ b/src/handlers/v1/ws/relays/mod.rs @@ -77,10 +77,12 @@ impl StreamHandler> for RelaysWs { match msg { ws::Message::Ping(msg) => { + log::trace!("Received ping from relay-client: {:?}", msg); self.hb = Instant::now(); ctx.pong(&msg) } ws::Message::Pong(_) => { + log::trace!("Received pong from relay-client"); self.hb = Instant::now(); } ws::Message::Text(_) => log::debug!("Received unexpected text in relays ws"),