From e8ccf9ba93834171bc2d15c15884c7214ffac08d Mon Sep 17 00:00:00 2001
From: Sosthene <contact@sosthene.net>
Date: Tue, 25 Jun 2024 11:23:15 +0200
Subject: [PATCH] scan at each new block

---
 src/main.rs | 10 ++++++++--
 1 file changed, 8 insertions(+), 2 deletions(-)

diff --git a/src/main.rs b/src/main.rs
index 0819a72..18649da 100644
--- a/src/main.rs
+++ b/src/main.rs
@@ -235,7 +235,7 @@ async fn handle_zmq(zmq_url: String, electrum_url: String) {
     let mut socket = zeromq::SubSocket::new();
     socket.connect(&zmq_url).await.unwrap();
     socket.subscribe("rawtx").await.unwrap();
-    // socket.subscribe("hashblock");
+    socket.subscribe("hashblock").await.unwrap();
     loop {
         let core_msg = match socket.recv().await {
             Ok(m) => m,
@@ -260,7 +260,13 @@ async fn handle_zmq(zmq_url: String, electrum_url: String) {
                         continue;
                     }
                 },
-                Ok("hashblock") => todo!(),
+                Ok("hashblock") => match scan_blocks(0, &electrum_url) {
+                    Ok(_) => continue,
+                    Err(e) => {
+                        error!("{}", e);
+                        continue;
+                    }
+                },
                 _ => {
                     error!("Unexpected message in zmq");
                     continue;