diff --git a/pallas-miniprotocols/src/txmonitor/codec.rs b/pallas-miniprotocols/src/txmonitor/codec.rs index 878f314..10f9cdf 100644 --- a/pallas-miniprotocols/src/txmonitor/codec.rs +++ b/pallas-miniprotocols/src/txmonitor/codec.rs @@ -53,7 +53,7 @@ impl<'b> Decode<'b, ()> for Message { log::trace!("Decoding 6, 2. Array: {:?}", de); let tag: Result = d.u8(); let mut tx = None; - if let Ok(_) = tag { + if tag.is_ok() { log::trace!("Decoding 6, Tag: {:?}", tag); let det = d.tag(); log::trace!("Decoding 6, Bytes: {:?}", det); @@ -74,14 +74,15 @@ impl<'b> Decode<'b, ()> for Message { 9 => Ok(Message::MsgQuery(MsgRequest::MsgGetSizes)), 10 => { d.array()?; - let capacity = d.decode()?; + let capacity_in_bytes = d.decode()?; let size_in_bytes = d.decode()?; - let number_of_tx = d.decode()?; + let number_of_txs = d.decode()?; + Ok(Message::MsgResponse(MsgResponse::MsgReplyGetSizes( MempoolSizeAndCapacity { - capacity_in_bytes: capacity, - size_in_bytes: size_in_bytes, - number_of_txs: number_of_tx, + capacity_in_bytes, + size_in_bytes, + number_of_txs, }, ))) } diff --git a/pallas-miniprotocols/src/txmonitor/mod.rs b/pallas-miniprotocols/src/txmonitor/mod.rs index 022f11f..153d76b 100644 --- a/pallas-miniprotocols/src/txmonitor/mod.rs +++ b/pallas-miniprotocols/src/txmonitor/mod.rs @@ -69,7 +69,7 @@ where { pub fn initial(state: State) -> Self { Self { - state: state, + state, snapshot: None, request: None, output: None, @@ -234,7 +234,7 @@ where State::StBusy(StBusyKind::GetSizes), Message::MsgResponse(MsgResponse::MsgReplyGetSizes(msc)), ) => self.on_reply_get_size(msc), - (state, msg) => Err(MachineError::invalid_msg::(&state, &msg)), + (state, msg) => Err(MachineError::invalid_msg::(state, &msg)), } } }