feat: Parallelize header validation with rayon (#243)

Author: xdustinface

dash-spv/Cargo.toml

@@ -46,6 +46,9 @@ rand = "0.8"
 hex = "0.4"
 indexmap = "2.0"
 
+# Parallelization
+rayon = "1.11"
+
 # Terminal UI (optional)
 crossterm = { version = "0.27", optional = true }
 

dash-spv/src/client/sync_coordinator.rs

@@ -19,7 +19,6 @@ use crate::network::NetworkManager;
 use crate::storage::StorageManager;
 use crate::sync::headers::validate_headers;
 use crate::types::{CachedHeader, DetailedSyncProgress, SyncProgress};
-use crate::ValidationMode;
 use key_wallet_manager::wallet_interface::WalletInterface;
 use std::time::{Duration, Instant, SystemTime};
 use tokio::sync::mpsc::UnboundedReceiver;
@@ -947,7 +946,7 @@ impl<
                 // come from storage.
                 let cached_headers =
                     headers.iter().map(|h| CachedHeader::new(*h)).collect::<Vec<CachedHeader>>();
-                if let Err(e) = validate_headers(&cached_headers, ValidationMode::Basic) {
+                if let Err(e) = validate_headers(&cached_headers) {
                     tracing::error!(
                         "Header validation failed for range {}..{}: {:?}",
                         current_height,

dash-spv/src/sync/headers/manager.rs

@@ -15,6 +15,7 @@ use crate::storage::StorageManager;
 use crate::sync::headers::validate_headers;
 use crate::sync::headers2::Headers2StateManager;
 use crate::types::{CachedHeader, ChainState};
+use crate::ValidationMode;
 use std::sync::Arc;
 use tokio::sync::RwLock;
 
@@ -203,11 +204,13 @@ impl<S: StorageManager + Send + Sync + 'static, N: NetworkManager + Send + Sync
             }
         }
 
-        validate_headers(&cached_headers, self.config.validation_mode).map_err(|e| {
-            let error = format!("Header validation failed: {}", e);
-            tracing::error!(error);
-            SyncError::Validation(error)
-        })?;
+        if self.config.validation_mode != ValidationMode::None {
+            validate_headers(&cached_headers).map_err(|e| {
+                let error = format!("Header validation failed: {}", e);
+                tracing::error!(error);
+                SyncError::Validation(error)
+            })?;
+        }
 
         self.last_sync_progress = std::time::Instant::now();