From aaeb05c716cb746ee7c746f4eefa75ebba3f703e Mon Sep 17 00:00:00 2001 From: tv Date: Sat, 31 Oct 2026 04:50:14 +0100 Subject: unify wire encoder --- src/transport/libp2p/mod.rs | 10 +--------- 1 file changed, 1 insertion(+), 9 deletions(-) (limited to 'src/transport/libp2p/mod.rs') 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 { - 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<()> { -- cgit v1.3.1