Log more information about failed deserializations

Log more information when messages over the websocket fail to
deserialize properly.

1 files changed, 16 insertions, 2 deletions

diff --git a/src/internal/ws_impl.rs b/src/internal/ws_impl.rs
index 8c10264..5d8969b 100644
--- a/src/internal/ws_impl.rs
+++ b/src/internal/ws_impl.rs
@@ -20,11 +20,25 @@ impl ReceiverExt for WsClient<TlsStream<TcpStream>> {
     fn recv_json(&mut self) -> Result<Option<Value>> {
         Ok(match self.recv_message()? {
             OwnedMessage::Binary(bytes) => {
-                serde_json::from_reader(ZlibDecoder::new(&bytes[..])).map(Some)?
+                serde_json::from_reader(ZlibDecoder::new(&bytes[..]))
+                    .map(Some)
+                    .map_err(|why| {
+                        warn!("Err deserializing bytes: {:?}; bytes: {:?}", why, bytes);
+
+                        why
+                    })?
             },
             OwnedMessage::Close(data) => return Err(Error::Gateway(GatewayError::Closed(data))),
             OwnedMessage::Text(payload) => {
-                serde_json::from_str(&payload).map(Some)?
+                serde_json::from_str(&payload).map(Some).map_err(|why| {
+                    warn!(
+                        "Err deserializing text: {:?}; text: {}",
+                        why,
+                        payload,
+                    );
+
+                    why
+                })?
             },
             OwnedMessage::Ping(x) => {
                 self.send_message(&OwnedMessage::Pong(x))