aljaz/sphinx-key
1
1
Fork 0
mirror of https://github.com/stakwork/sphinx-key.git synced 2025-12-17 23:34:19 +01:00
Code Issues Packages Projects Releases Wiki Activity

chaintracker logs

Browse Source
This commit is contained in:
Evan Feenstra
2023-06-26 10:41:50 -07:00
parent d407ccfe35
commit 1b54c5358c
1 changed files with 4 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
broker/src/chain_tracker.rs
View File

@@ -29,13 +29,17 @@ impl MqttSignerPort {
async fn send_request(&self, message: Vec<u8>) -> Result<oneshot::Receiver<ChannelReply>> {
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<ChannelReply>) -> ClientResult<Vec<u8>> {
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)
}
}