From 9699ef2fa12a50d0bba035c5d0cdeb7e7d981fbe Mon Sep 17 00:00:00 2001 From: Deirdre Connolly Date: Thu, 3 Oct 2019 19:59:39 -0400 Subject: [PATCH] Codec::read_tx() --- zebra-network/src/protocol/codec.rs | 10 +++++++--- 1 file changed, 7 insertions(+), 3 deletions(-) diff --git a/zebra-network/src/protocol/codec.rs b/zebra-network/src/protocol/codec.rs index 28f08393..bb815446 100644 --- a/zebra-network/src/protocol/codec.rs +++ b/zebra-network/src/protocol/codec.rs @@ -11,6 +11,7 @@ use tokio::codec::{Decoder, Encoder}; use zebra_chain::{ block::BlockHeader, serialization::{ReadZcashExt, WriteZcashExt, ZcashDeserialize, ZcashSerialize}, + transaction::Transaction, types::{BlockHeight, Sha256dChecksum}, }; @@ -485,9 +486,12 @@ impl Codec { bail!("unimplemented message type") } - fn read_tx(&self, mut _reader: R) -> Result { - trace!("tx"); - bail!("unimplemented message type") + fn read_tx(&self, mut reader: R) -> Result { + Ok(Message::Tx { + version: Version(reader.read_u32::()?), + + transaction: Transaction::zcash_deserialize(&mut reader)?, + }) } fn read_mempool(&self, mut _reader: R) -> Result {