diff --git a/zebra-network/src/protocol/codec.rs b/zebra-network/src/protocol/codec.rs index 28f083935..bb815446d 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 {