From a25a5b95973877e1c94695f0d25f967007439391 Mon Sep 17 00:00:00 2001 From: Odysseas Gabrielides Date: Tue, 19 Nov 2024 16:31:53 +0200 Subject: [PATCH] logs before decoding zmq messages --- src/components/core_zmq_listener.rs | 4 ++++ 1 file changed, 4 insertions(+) diff --git a/src/components/core_zmq_listener.rs b/src/components/core_zmq_listener.rs index e94a6ad0..d9dc3761 100644 --- a/src/components/core_zmq_listener.rs +++ b/src/components/core_zmq_listener.rs @@ -140,6 +140,7 @@ impl CoreZMQListener { // Create a cursor over the data_bytes let mut cursor = Cursor::new(data_bytes); + println!("zmq_rawchainlock:{:?}", data_bytes); // Deserialize the LLMQChainLock match Block::consensus_decode(&mut cursor) { @@ -169,6 +170,7 @@ impl CoreZMQListener { // Create a cursor over the data_bytes let mut cursor = Cursor::new(data_bytes); + println!("zmq_rawtxlocksig:{:?}", data_bytes); // Deserialize the transaction match Transaction::consensus_decode(&mut cursor) { @@ -328,6 +330,7 @@ impl CoreZMQListener { "rawchainlock" => { // Deserialize the Block let mut cursor = Cursor::new(data_bytes); + println!("zmq_rawchainlock:{:?}", data_bytes); match Block::consensus_decode(&mut cursor) { Ok(block) => { if let Err(e) = sender_clone.send(( @@ -351,6 +354,7 @@ impl CoreZMQListener { "rawtxlocksig" => { // Deserialize the Transaction and InstantLock let mut cursor = Cursor::new(data_bytes); + println!("zmq_rawtxlocksig:{:?}", data_bytes); match Transaction::consensus_decode(&mut cursor) { Ok(tx) => { match InstantLock::consensus_decode(&mut cursor)