ffi

Author: xdustinface

dash-spv-ffi/src/callbacks.rs

@@ -406,7 +406,7 @@ impl FFISyncEventCallbacks {
                 }
             }
             SyncEvent::SyncComplete {
-                header_tip,
+                header_tip, ..
             } => {
                 if let Some(cb) = self.on_sync_complete {
                     cb(*header_tip, self.user_data);

dash-spv/src/sync/events.rs

@@ -144,11 +144,17 @@ pub enum SyncEvent {
 
     /// Sync has reached the chain tip (all managers idle).
     ///
+    /// Emitted on every not-synced to synced transition. Cycle 0 is the
+    /// initial sync; subsequent cycles are incremental syncs triggered by
+    /// new blocks arriving from the network.
+    ///
     /// Emitted by: Coordinator
     /// Consumed by: External listeners
     SyncComplete {
         /// Final header tip height
         header_tip: u32,
+        /// Sync cycle (0 = initial, 1+ = incremental)
+        cycle: u32,
     },
 }
 
@@ -235,8 +241,9 @@ impl SyncEvent {
             }
             SyncEvent::SyncComplete {
                 header_tip,
+                cycle,
             } => {
-                format!("SyncComplete(tip={})", header_tip)
+                format!("SyncComplete(tip={}, cycle={})", header_tip, cycle)
             }
         }
     }

dash-spv/src/sync/sync_coordinator.rs

@@ -337,6 +337,7 @@ async fn run_progress_task(
     let mut merged = select_all(streams);
     let mut progress = SyncProgress::default();
     let mut was_synced = false;
+    let mut sync_cycle: u32 = 0;
 
     loop {
         tokio::select! {
@@ -349,10 +350,11 @@ async fn run_progress_task(
                 let is_synced = progress.is_synced();
                 if is_synced && !was_synced {
                     let duration = sync_start_time.elapsed();
-                    tracing::info!("Sync complete in {:.2}s", duration.as_secs_f64());
+                    tracing::info!("Sync complete in {:.2}s (cycle {})", duration.as_secs_f64(), sync_cycle);
 
                     let header_tip = progress.headers().ok().map(|h| h.current_height()).unwrap_or(0);
-                    let _ = sync_event_sender.send(SyncEvent::SyncComplete { header_tip });
+                    let _ = sync_event_sender.send(SyncEvent::SyncComplete { header_tip, cycle: sync_cycle });
+                    sync_cycle += 1;
                 }
                 was_synced = is_synced;
             }