Decode trait function takes &self as argument

Author: acerone85

crates/fuel-core/src/p2p_test_helpers.rs

@@ -25,7 +25,7 @@ use fuel_core_chain_config::{
 use fuel_core_p2p::{
     codecs::{
         request_response::RequestResponseMessageHandler,
-        unbounded::GossipsubMessageHandler,
+        gossipsub::GossipsubMessageHandler,
     },
     network_service::FuelP2PService,
     p2p_service::FuelP2PEvent,

crates/services/p2p/src/codecs.rs

@@ -37,7 +37,7 @@ pub trait Encode<T: ?Sized> {
 pub trait Decode<T> {
     type Error;
     /// Decodes the type `T` from the bytes.
-    fn decode(bytes: &[u8]) -> Result<T, Self::Error>;
+    fn decode(&self, bytes: &[u8]) -> Result<T, Self::Error>;
 }
 
 impl<'a> Encoder for Cow<'a, [u8]> {

crates/services/p2p/src/codecs/gossipsub.rs

@@ -44,7 +44,7 @@ where
     ) -> Result<Self::ResponseMessage, io::Error> {
         let decoded_response = match gossipsub_tag {
             GossipTopicTag::NewTx => {
-                GossipsubMessage::NewTx(Format::decode(encoded_data)?)
+                GossipsubMessage::NewTx(self.data_format.decode(encoded_data)?)
             }
         };
 

crates/services/p2p/src/codecs/postcard.rs

@@ -30,7 +30,7 @@ impl RequestResponseMessageHandler<PostcardDataFormat> {
 impl GossipsubMessageHandler<PostcardDataFormat> {
     pub fn new() -> Self {
         GossipsubMessageHandler {
-            data_format: PostcardDataFormat,
+            codec: PostcardDataFormat,
         }
     }
 }
@@ -55,7 +55,7 @@ where
 {
     type Error = io::Error;
 
-    fn decode(bytes: &[u8]) -> Result<T, Self::Error> {
+    fn decode(&self, bytes: &[u8]) -> Result<T, Self::Error> {
         postcard::from_bytes(bytes)
             .map_err(|e| io::Error::new(io::ErrorKind::Other, e.to_string()))
     }
@@ -228,7 +228,7 @@ mod tests {
         let deserialized_as_v1 =
             // We cannot access the codec trait from an old node here, 
             // so we deserialize directly using the `V1ResponseMessage` type.
-            <PostcardDataFormat as Decode<V1ResponseMessage>>::decode(&buf).expect("Deserialization as V1ResponseMessage should succeed");
+            codec.data_format.decode(&buf).expect("Deserialization as V1ResponseMessage should succeed");
 
         // Then
         assert!(matches!(

crates/services/p2p/src/codecs/request_response.rs

@@ -68,7 +68,7 @@ where
             .take(self.max_response_size as u64)
             .read_to_end(&mut response)
             .await?;
-        Format::decode(&response)
+        self.data_format.decode(&response)
     }
 
     async fn read_response<T>(
@@ -87,13 +87,11 @@ where
 
         match protocol {
             RequestResponseProtocol::V1 => {
-                let v1_response =
-                    <Format as Decode<V1ResponseMessage>>::decode(&response)?;
+                let v1_response: V1ResponseMessage =
+                    self.data_format.decode(&response)?;
                 Ok(v1_response.into())
             }
-            RequestResponseProtocol::V2 => {
-                <Format as Decode<V2ResponseMessage>>::decode(&response)
-            }
+            RequestResponseProtocol::V2 => self.data_format.decode(&response),
         }
     }