Fix excess warnings with message decoding length for Open/Close messa…

…ges.
ttiurani · Nov 19, 2023 · 54d4d91 · 54d4d91
1 parent 9effc74
commit 54d4d91
Showing 1 changed file with 5 additions and 3 deletions.
diff --git a/src/message.rs b/src/message.rs
@@ -124,7 +124,9 @@ impl Frame {
                         )?;
                         if length != body_len as usize {
                             tracing::warn!(
-                                "Did not know what to do with all the bytes, got {} but decoded {}",
+                                "Did not know what to do with all the bytes, got {} but decoded {}. \
+                                This may be because the peer implements a newer protocol version \
+                                that has extra fields.",
                                 body_len,
                                 length
                             );
@@ -202,11 +204,11 @@ impl Frame {
             } else if buf[1] == 0x01 {
                 // Open message
                 let (channel_message, length) = ChannelMessage::decode_open_message(&buf[2..])?;
-                Ok((Frame::MessageBatch(vec![channel_message]), length))
+                Ok((Frame::MessageBatch(vec![channel_message]), length + 2))
             } else if buf[1] == 0x03 {
                 // Close message
                 let (channel_message, length) = ChannelMessage::decode_close_message(&buf[2..])?;
-                Ok((Frame::MessageBatch(vec![channel_message]), length))
+                Ok((Frame::MessageBatch(vec![channel_message]), length + 2))
             } else {
                 Err(io::Error::new(
                     io::ErrorKind::InvalidData,