unify wire encoder

1 files changed, 1 insertions, 9 deletions

diff --git a/src/transport/libp2p/mod.rs b/src/transport/libp2p/mod.rs
index 86e7734..06e9e15 100644
--- a/src/transport/libp2p/mod.rs
+++ b/src/transport/libp2p/mod.rs
@@ -517,15 +517,7 @@ impl Transport for Libp2pTransport {
     }
 
     fn encode(&self, peer: &str, message: &ParsedMessage) -> Result<EncodedMessage> {
-        let body = wire::encode(message)?;
-        Ok(EncodedMessage {
-            peer: peer.to_owned(),
-            address: peer.to_owned(),
-            payload_len: body.len(),
-            body: body.into(),
-            kind: message.kind(),
-            message: None,
-        })
+        wire::encoded(peer, message)
     }
 
     async fn send_encoded(&self, message: &EncodedMessage) -> Result<()> {