From 6d8cacc900dfa42fc91c84b237f1dd72397ffbce Mon Sep 17 00:00:00 2001 From: mfahampshire Date: Thu, 24 Jul 2025 14:12:03 +0200 Subject: [PATCH] commenting --- sdk/rust/nym-sdk/src/stream_wrapper.rs | 3 +++ .../nym-sdk/src/stream_wrapper/mixnet_stream_wrapper.rs | 8 ++++---- 2 files changed, 7 insertions(+), 4 deletions(-) diff --git a/sdk/rust/nym-sdk/src/stream_wrapper.rs b/sdk/rust/nym-sdk/src/stream_wrapper.rs index 560e01a996..c13ec4aa68 100644 --- a/sdk/rust/nym-sdk/src/stream_wrapper.rs +++ b/sdk/rust/nym-sdk/src/stream_wrapper.rs @@ -1,3 +1,6 @@ +// Copyright 2024 - Nym Technologies SA +// SPDX-License-Identifier: GPL-2.0-only + //! TODO mod mixnet_stream_wrapper; diff --git a/sdk/rust/nym-sdk/src/stream_wrapper/mixnet_stream_wrapper.rs b/sdk/rust/nym-sdk/src/stream_wrapper/mixnet_stream_wrapper.rs index 8733817983..d5edb576f6 100644 --- a/sdk/rust/nym-sdk/src/stream_wrapper/mixnet_stream_wrapper.rs +++ b/sdk/rust/nym-sdk/src/stream_wrapper/mixnet_stream_wrapper.rs @@ -128,7 +128,7 @@ impl MixStream { /// Convenience method for just piping bytes into the Mixnet. pub async fn write_bytes(&mut self, data: &[u8]) -> Result<(), Error> { let input_message = if self.peer_surbs.is_some() { - info!("Writing reply with SURBs"); + info!("Writing {} bytes, sending with SURBs", data.len()); InputMessage::Reply { recipient_tag: (self.peer_surbs.expect("No Peer SURBs set")), data: (data.to_owned()), @@ -136,7 +136,7 @@ impl MixStream { max_retransmissions: (Some(5)), // TODO check with Drazen - guessing here } } else { - info!("Writing outgoing reply using Nym address"); + info!("Writing {} bytes", data.len()); InputMessage::Anonymous { recipient: (self.peer.expect("No Peer set")), data: (data.to_owned()), @@ -149,10 +149,10 @@ impl MixStream { let mut codec = InputMessageCodec {}; let mut serialized_bytes = BytesMut::new(); codec.encode(input_message, &mut serialized_bytes)?; - info!("Serialized bytes: {:?}", serialized_bytes); + debug!("Serialized bytes: {:?}", serialized_bytes); self.write_all(&serialized_bytes).await?; - info!("Wrote serialized bytes"); + debug!("Wrote serialized bytes"); self.flush().await?; debug!("Flushed");