chore: Some restructuring in dash-spv::sync (#236)

Author: xdustinface

dash-spv/src/client/core.rs

@@ -20,7 +20,7 @@ use crate::mempool_filter::MempoolFilter;
 use crate::network::NetworkManager;
 use crate::storage::StorageManager;
 use crate::sync::filters::FilterNotificationSender;
-use crate::sync::sequential::SyncManager;
+use crate::sync::SyncManager;
 use crate::types::{ChainState, DetailedSyncProgress, MempoolState, SpvEvent, SpvStats};
 use crate::validation::ValidationManager;
 use key_wallet_manager::wallet_interface::WalletInterface;

dash-spv/src/client/filter_sync.rs

@@ -3,7 +3,7 @@
 use crate::error::{Result, SpvError};
 use crate::network::NetworkManager;
 use crate::storage::StorageManager;
-use crate::sync::sequential::SyncManager;
+use crate::sync::SyncManager;
 use crate::types::FilterMatch;
 use crate::types::SpvStats;
 use key_wallet_manager::wallet_interface::WalletInterface;

dash-spv/src/client/lifecycle.rs

@@ -17,7 +17,7 @@ use crate::error::{Result, SpvError};
 use crate::mempool_filter::MempoolFilter;
 use crate::network::NetworkManager;
 use crate::storage::StorageManager;
-use crate::sync::sequential::SyncManager;
+use crate::sync::SyncManager;
 use crate::types::{ChainState, MempoolState, SpvStats};
 use crate::validation::ValidationManager;
 use dashcore::network::constants::NetworkExt;

dash-spv/src/client/message_handler.rs

@@ -5,7 +5,7 @@ use crate::error::{Result, SpvError};
 use crate::mempool_filter::MempoolFilter;
 use crate::network::NetworkManager;
 use crate::storage::StorageManager;
-use crate::sync::sequential::SyncManager;
+use crate::sync::SyncManager;
 use crate::types::{MempoolState, SpvEvent, SpvStats};
 // Removed local ad-hoc compact filter construction in favor of always processing full blocks
 use key_wallet_manager::wallet_interface::WalletInterface;

dash-spv/src/client/message_handler_test.rs

@@ -12,7 +12,7 @@ mod tests {
     use crate::storage::memory::MemoryStorageManager;
     use crate::storage::StorageManager;
     use crate::sync::filters::FilterNotificationSender;
-    use crate::sync::sequential::SyncManager;
+    use crate::sync::SyncManager;
     use crate::types::{ChainState, MempoolState, SpvEvent, SpvStats};
     use crate::validation::ValidationManager;
     use crate::wallet::Wallet;

dash-spv/src/client/progress.rs

@@ -8,7 +8,7 @@
 use crate::error::Result;
 use crate::network::NetworkManager;
 use crate::storage::StorageManager;
-use crate::sync::sequential::phases::SyncPhase;
+use crate::sync::SyncPhase;
 use crate::types::{SpvStats, SyncProgress, SyncStage};
 use key_wallet_manager::wallet_interface::WalletInterface;
 

dash-spv/src/sync/headers.rs dash-spv/src/sync/headers/manager.rsdash-spv/src/sync/headers.rs renamed to dash-spv/src/sync/headers/manager.rs

@@ -12,7 +12,7 @@ use crate::client::ClientConfig;
 use crate::error::{SyncError, SyncResult};
 use crate::network::NetworkManager;
 use crate::storage::StorageManager;
-use crate::sync::headers2_state::Headers2StateManager;
+use crate::sync::headers2::Headers2StateManager;
 use crate::types::{CachedHeader, ChainState};
 use std::sync::Arc;
 use tokio::sync::RwLock;
@@ -611,10 +611,8 @@ impl<S: StorageManager + Send + Sync + 'static, N: NetworkManager + Send + Sync
 
                     // If we failed due to missing previous header, and we're at genesis,
                     // this might be a protocol issue where peer expects us to have genesis in compression state
-                    if matches!(
-                        e,
-                        crate::sync::headers2_state::ProcessError::DecompressionError(0, _)
-                    ) && self.chain_state.read().await.tip_height() == 0
+                    if matches!(e, crate::sync::headers2::ProcessError::DecompressionError(0, _))
+                        && self.chain_state.read().await.tip_height() == 0
                     {
                         tracing::warn!(
                         "Headers2 decompression failed at genesis. Peer may be sending compressed headers that reference genesis. Consider falling back to regular headers."

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

@@ -0,0 +1,5 @@
+//! Header synchronization with fork detection and reorganization handling.
+
+mod manager;
+
+pub use manager::{HeaderSyncManager, ReorgConfig};

dash-spv/src/sync/headers2_state.rs dash-spv/src/sync/headers2/manager.rsdash-spv/src/sync/headers2_state.rs renamed to dash-spv/src/sync/headers2/manager.rs

@@ -0,0 +1,5 @@
+//! Headers2 state management for compressed header synchronization.
+
+mod manager;
+
+pub use manager::{Headers2StateManager, Headers2Stats, ProcessError};