diff --git a/broker/src/chain_tracker.rs b/broker/src/chain_tracker.rs index 797234f..a3c678e 100644 --- a/broker/src/chain_tracker.rs +++ b/broker/src/chain_tracker.rs @@ -29,13 +29,17 @@ impl MqttSignerPort { async fn send_request(&self, message: Vec) -> Result> { let m = parser::raw_request_from_bytes(message, 0, [0;33], 0)?; let (request, reply_rx) = ChannelRequest::new(topics::VLS, m); + log::info!("=> MqttSignerPort send request now"); self.sender.send(request).await.map_err(|_| Error::Eof)?; + log::info!("=> MqttSignerPort sent"); Ok(reply_rx) } async fn get_reply(&self, reply_rx: oneshot::Receiver) -> ClientResult> { let reply = reply_rx.await.map_err(|_| Error::Eof)?; + log::info!("=> MqttSignerPort got response {:?}", reply.reply); let r = parser::raw_response_from_bytes(reply.reply, 0)?; + log::info!("=> MqttSignerPort parsed response {:?}", r); Ok(r) } }