From e06d7e1c06a45813b7ccf0c2f7c03147d323aaf9 Mon Sep 17 00:00:00 2001
From: grumbach <anselmega@gmail.com>
Date: Wed, 5 Jun 2024 13:44:50 +0200
Subject: [PATCH] fix: sleep less as some UTXOs are false alerts

---
 sn_auditor/src/dag_db.rs            |  2 +-
 sn_client/src/audit/dag_crawling.rs | 11 +++++++++++
 2 files changed, 12 insertions(+), 1 deletion(-)

diff --git a/sn_auditor/src/dag_db.rs b/sn_auditor/src/dag_db.rs
index 0ac515d4bc..54a1a31108 100644
--- a/sn_auditor/src/dag_db.rs
+++ b/sn_auditor/src/dag_db.rs
@@ -36,7 +36,7 @@ lazy_static! {
         std::env::var("UTXO_REATTEMPT_INTERVAL")
             .unwrap_or("3600".to_string())
             .parse::<u64>()
-            .unwrap_or(3600)
+            .unwrap_or(300)
     );
 
     /// time in seconds to rest between DAG crawls
diff --git a/sn_client/src/audit/dag_crawling.rs b/sn_client/src/audit/dag_crawling.rs
index 2e6553f8a9..c159576777 100644
--- a/sn_client/src/audit/dag_crawling.rs
+++ b/sn_client/src/audit/dag_crawling.rs
@@ -75,9 +75,15 @@ impl Client {
         // forward spends to processing if provided
         let build_handle: tokio::task::JoinHandle<Result<SpendDag, WalletError>> =
             tokio::spawn(async move {
+                debug!("Starting building DAG from {spend_addr:?}...");
+                let now = std::time::Instant::now();
                 let mut dag = SpendDag::new(spend_addr);
                 while let Some(spend) = rx.recv().await {
                     let addr = spend.address();
+                    debug!(
+                        "Inserting spend at {addr:?} size: {}",
+                        dag.all_spends().len()
+                    );
                     dag.insert(addr, spend.clone());
                     if let Some(sender) = &spend_processing {
                         sender
@@ -86,6 +92,11 @@ impl Client {
                             .map_err(|e| WalletError::SpendProcessing(e.to_string()))?;
                     }
                 }
+                info!(
+                    "Done gathering DAG of size: {} in {:?}",
+                    dag.all_spends().len(),
+                    now.elapsed()
+                );
                 Ok(dag)
             });