WIP: feat/platform-wallet2 — do not review

dash-spv/src/client/transactions.rs

@@ -1,6 +1,6 @@
 //! Transaction-related client APIs (e.g., broadcasting)
 
-use crate::error::{NetworkError, Result, SpvError, SyncError};
+use crate::error::{NetworkError, Result, SpvError};
 use crate::network::NetworkManager;
 use crate::storage::StorageManager;
 use dashcore::network::message::NetworkMessage;
@@ -16,10 +16,6 @@ impl<W: WalletInterface, N: NetworkManager, S: StorageManager, H: EventHandler>
     /// The transaction is also injected into the local message pipeline so that
     /// the mempool manager processes it immediately.
     pub async fn broadcast_transaction(&self, tx: &dashcore::Transaction) -> Result<()> {
-        if !self.sync_progress().await.is_synced() {
-            return Err(SpvError::Sync(SyncError::NotSynced));
-        }
-
         let network_guard = self.network.lock().await;
 
         if network_guard.peer_count() == 0 {

dash-spv/src/error.rs

@@ -236,6 +236,10 @@ pub enum SyncError {
     /// Operation requires the client to be fully synced
     #[error("Client is not synced")]
     NotSynced,
+
+    /// Wallet error during block processing (e.g. persistence failure)
+    #[error("Wallet error: {0}")]
+    Wallet(String),
 }
 
 impl SyncError {
@@ -252,6 +256,7 @@ impl SyncError {
             SyncError::Storage(_) => "storage",
             SyncError::Headers2DecompressionFailed(_) => "headers2",
             SyncError::MasternodeSyncFailed(_) => "masternode",
+            SyncError::Wallet(_) => "wallet",
             // Deprecated variant - should not be used
             #[allow(deprecated)]
             SyncError::SyncFailed(_) => "unknown",
@@ -329,6 +334,12 @@ impl From<ValidationError> for SyncError {
     }
 }
 
+impl From<key_wallet_manager::WalletError> for SyncError {
+    fn from(err: key_wallet_manager::WalletError) -> Self {
+        SyncError::Wallet(err.to_string())
+    }
+}
+
 #[cfg(test)]
 mod tests {
     use super::*;

dash-spv/src/network/constants.rs

@@ -24,6 +24,39 @@ pub const MAINNET_DNS_SEEDS: &[&str] = &[
 // DNS seeds for Dash testnet
 pub const TESTNET_DNS_SEEDS: &[&str] = &["testnet-seed.dashdot.io"];
 
+// Fixed peer IPs for Dash testnet (hp-masternodes)
+pub const TESTNET_FIXED_PEERS: &[&str] = &[
+    "68.67.122.1",
+    "68.67.122.2",
+    "68.67.122.3",
+    "68.67.122.4",
+    "68.67.122.5",
+    "68.67.122.6",
+    "68.67.122.7",
+    "68.67.122.8",
+    "68.67.122.9",
+    "68.67.122.10",
+    "68.67.122.11",
+    "68.67.122.12",
+    "68.67.122.13",
+    "68.67.122.14",
+    "68.67.122.15",
+    "68.67.122.16",
+    "68.67.122.17",
+    "68.67.122.18",
+    "68.67.122.19",
+    "68.67.122.20",
+    "68.67.122.21",
+    "68.67.122.22",
+    "68.67.122.23",
+    "68.67.122.24",
+    "68.67.122.25",
+    "68.67.122.26",
+    "68.67.122.27",
+    "68.67.122.28",
+    "68.67.122.29",
+];
+
 // Peer exchange
 pub const MAX_ADDR_TO_SEND: usize = 1000;
 pub const MAX_ADDR_TO_STORE: usize = 2000;

dash-spv/src/network/discovery.rs

@@ -60,11 +60,21 @@ impl DnsDiscovery {
             }
         }
 
+        // For testnet, add fixed peers as fallback if DNS returned few/no results
+        if matches!(network, Network::Testnet) {
+            use super::constants::TESTNET_FIXED_PEERS;
+            for ip_str in TESTNET_FIXED_PEERS {
+                if let Ok(ip) = ip_str.parse::<IpAddr>() {
+                    addresses.push(SocketAddr::new(ip, port));
+                }
+            }
+        }
+
         // Deduplicate addresses
         addresses.sort();
         addresses.dedup();
 
-        tracing::info!("Discovered {} unique peer addresses from DNS seeds", addresses.len());
+        tracing::info!("Discovered {} unique peer addresses for {:?}", addresses.len(), network);
         addresses
     }
 

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

@@ -84,7 +84,7 @@ impl<H: BlockHeaderStorage, B: BlockStorage, W: WalletInterface> BlocksManager<H
 
             // Process block through wallet
             let mut wallet = self.wallet.write().await;
-            let result = wallet.process_block(&block, height).await;
+            let result = wallet.process_block(&block, height).await?;
             drop(wallet);
 
             let total_relevant = result.relevant_tx_count();

dash-spv/src/test_utils/event_handler.rs

@@ -23,10 +23,10 @@ pub struct TestEventHandler {
 
 impl TestEventHandler {
     pub fn new() -> Self {
-        let (sync_tx, _) = broadcast::channel(256);
-        let (network_tx, _) = broadcast::channel(256);
+        let (sync_tx, _) = broadcast::channel(10000);
+        let (network_tx, _) = broadcast::channel(10000);
         let (progress_tx, _) = watch::channel(SyncProgress::default());
-        let (wallet_tx, _) = broadcast::channel(256);
+        let (wallet_tx, _) = broadcast::channel(10000);
         Self {
             sync_tx,
             network_tx,