octo
/
Zebra
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Codec::read_tx()

This commit is contained in:
Deirdre Connolly 2019-10-03 19:59:39 -04:00 committed by Deirdre Connolly
parent 565dc92afe
commit 9699ef2fa1
1 changed files with 7 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
zebra-network/src/protocol/codec.rs
View File

@ -11,6 +11,7 @@ use tokio::codec::{Decoder, Encoder};
use zebra_chain::{ use zebra_chain::{
block::BlockHeader, block::BlockHeader,
serialization::{ReadZcashExt, WriteZcashExt, ZcashDeserialize, ZcashSerialize}, serialization::{ReadZcashExt, WriteZcashExt, ZcashDeserialize, ZcashSerialize},
transaction::Transaction,
types::{BlockHeight, Sha256dChecksum}, types::{BlockHeight, Sha256dChecksum},
}; };
@ -485,9 +486,12 @@ impl Codec {
bail!("unimplemented message type") bail!("unimplemented message type")
} }
fn read_tx<R: Read>(&self, mut _reader: R) -> Result<Message, Error> { fn read_tx<R: Read>(&self, mut reader: R) -> Result<Message, Error> {
trace!("tx"); Ok(Message::Tx {
bail!("unimplemented message type") version: Version(reader.read_u32::<LittleEndian>()?),
transaction: Transaction::zcash_deserialize(&mut reader)?,
})
} }
fn read_mempool<R: Read>(&self, mut _reader: R) -> Result<Message, Error> { fn read_mempool<R: Read>(&self, mut _reader: R) -> Result<Message, Error> {