remove beetswap error prefix in messages

eigerco · Jun 11, 2024 · 1dc2c17 · 1dc2c17
1 parent 1f5ee85
commit 1dc2c17
Show file tree

Hide file tree

Showing 4 changed files with 10 additions and 16 deletions.
diff --git a/src/cid_prefix.rs b/src/cid_prefix.rs
@@ -90,7 +90,7 @@ impl CidPrefix {
     ) -> Result<CidGeneric<S>, MultihasherError> {
         if self.multihash_size > S {
             debug!(
-                "beetswap error: Multihash<{}> can not hold multihash of size {}",
+                "Multihash<{}> can not hold multihash of size {}",
                 S, self.multihash_size
             );
             return Err(MultihasherError::InvalidMultihashSize);

diff --git a/src/client.rs b/src/client.rs
@@ -570,7 +570,7 @@ impl<const S: usize> ClientConnectionHandler<S> {
     }
 
     fn close_sink_on_error(&mut self, location: &str) {
-        debug!("beetswap error: sink operation failed, closing: {location}");
+        debug!("sink operation failed, closing: {location}");
         self.sink_state = SinkState::None;
     }
 

diff --git a/src/incoming_stream.rs b/src/incoming_stream.rs
@@ -87,7 +87,7 @@ impl<const S: usize> futures_core::stream::Stream for IncomingStream<S> {
             let msg = match self.stream.poll_next_unpin(cx) {
                 Poll::Ready(Some(Ok(msg))) => msg,
                 Poll::Ready(Some(Err(e))) => {
-                    debug!("beetswap error: Message decoding failed: {e}");
+                    debug!("Message decoding failed: {e}");
                     return Poll::Ready(None);
                 }
                 Poll::Ready(None) => return Poll::Ready(None),
@@ -116,10 +116,7 @@ async fn process_message<const S: usize>(
         let cid = match CidGeneric::try_from(&block_presence.cid[..]) {
             Ok(cid) => cid,
             Err(e) => {
-                debug!(
-                    "beetswap error: Invalid CID bytes: {}: {:?}",
-                    e, block_presence.cid
-                );
+                debug!("Invalid CID bytes: {}: {:?}", e, block_presence.cid);
                 return None;
             }
         };
@@ -133,29 +130,26 @@ async fn process_message<const S: usize>(
 
     for payload in msg.payload {
         let Some(cid_prefix) = CidPrefix::from_bytes(&payload.prefix) else {
-            debug!(
-                "beeswap error: block.prefix not decodable: {:?}",
-                payload.prefix
-            );
+            debug!("block.prefix not decodable: {:?}", payload.prefix);
             return None;
         };
 
         let cid = match cid_prefix.to_cid(&multihasher, &payload.data).await {
             Ok(cid) => cid,
             Err(MultihasherError::UnknownMultihashCode) => {
                 debug!(
-                    "beetswap error: Multihasher non-fatal error: Unknown multihash code: {}",
+                    "Multihasher non-fatal error: Unknown multihash code: {}",
                     cid_prefix.multihash_code()
                 );
                 continue;
             }
             Err(MultihasherError::Custom(e)) => {
-                debug!("beetswap error: Multihasher non-fatal error: {e}");
+                debug!("Multihasher non-fatal error: {e}");
                 continue;
             }
             // Any other error is fatal and we need to close the stream.
             Err(e) => {
-                debug!("beetswap error: Multihasher fatal error: {e}");
+                debug!("Multihasher fatal error: {e}");
                 return None;
             }
         };

diff --git a/src/server.rs b/src/server.rs
@@ -271,7 +271,7 @@ where
                     self.outgoing_queue.push_back((cid, data));
                 }
                 Err(e) => {
-                    debug!("beetswap error: Fetching {cid} from blockstore failed: {e}");
+                    debug!("Fetching {cid} from blockstore failed: {e}");
                 }
             }
         }
@@ -393,7 +393,7 @@ impl<const S: usize> ServerConnectionHandler<S> {
     }
 
     fn close_sink_on_error(&mut self, location: &str) {
-        debug!("beetswap error: sink operation failed, closing: {location}");
+        debug!("sink operation failed, closing: {location}");
         self.sink = SinkState::None;
     }