Add TrustSync state to SyncStateChangedNotification

Added a new state called TrustSync to the SyncStateChangedNotification enum to share information about the processing of trusted blocks. The addition of TrustSync allows the program to notify about the number of trusted blocks processed in the last one second and the total number of such blocks processed till now. This is essential for improving the supervision of the synchronization process.

consensus/notify/src/notification.rs

@@ -182,6 +182,7 @@ pub enum SyncStateChangedNotification {
     Blocks { blocks: u64, progress: i64 },
     UtxoResync,
     UtxoSync { chunks: u64, total: u64 },
+    TrustSync { processed: u64, total: u64 },
 }
 
 impl SyncStateChangedNotification {
@@ -204,4 +205,8 @@ impl SyncStateChangedNotification {
     pub fn new_utxo_sync(chunks: u64, total: u64) -> Self {
         Self::UtxoSync { chunks, total }
     }
+
+    pub fn new_trust_sync(processed: u64, total: u64) -> Self {
+        Self::TrustSync { processed, total }
+    }
 }

protocol/flows/src/v5/ibd/flow.rs

@@ -290,6 +290,15 @@ impl IbdFlow {
             let passed = now.duration_since(last_time);
             if passed > Duration::from_secs(1) {
                 info!("Processed {} trusted blocks in the last {:.2}s (total {})", i - last_index, passed.as_secs_f64(), i);
+                self.notification_root
+                    .as_ref()
+                    .unwrap()
+                    .notify(Notification::SyncStateChanged(SyncStateChangedNotification::new_trust_sync(
+                        (i - last_index) as u64,
+                        i as u64,
+                    )))
+                    .expect("expecting an open unbounded channel");
+
                 last_time = now;
                 last_index = i;
             }

rpc/core/src/convert/notification.rs

@@ -108,6 +108,9 @@ impl From<&consensus_notify::SyncStateChangedNotification> for SyncStateChangedN
             consensus_notify::SyncStateChangedNotification::UtxoSync { chunks, total } => {
                 Self::UtxoSync { chunks: *chunks, total: *total }
             }
+            consensus_notify::SyncStateChangedNotification::TrustSync { processed, total } => {
+                Self::TrustSync { processed: *processed, total: *total }
+            }
         }
     }
 }

rpc/core/src/model/message.rs

@@ -1097,6 +1097,12 @@ pub enum SyncStateChangedNotification {
         #[allow(dead_code)]
         total: u64,
     },
+    TrustSync {
+        #[allow(dead_code)]
+        processed: u64,
+        #[allow(dead_code)]
+        total: u64,
+    },
 }
 
 ///

rpc/grpc/core/proto/rpc.proto

@@ -779,6 +779,7 @@ message SyncStateChangedNotificationMessage {
     BlocksState blocks = 3;
     UtxoResyncState utxoResync = 4;
     UtxoSyncState utxoSync = 5;
+    TrustSyncState trustSync = 6;
   }
 }
 
@@ -802,4 +803,9 @@ message UtxoResyncState {}
 message UtxoSyncState {
   uint64 chunks = 1;
   uint64 total = 2;
+}
+
+message TrustSyncState {
+  uint64 processed = 1;
+  uint64 total = 2;
 }

rpc/grpc/core/src/convert/notification.rs

@@ -103,6 +103,12 @@ from!(item: &kaspa_rpc_core::SyncStateChangedNotification, SyncStateChangedNotif
                     total: *total
                 }))
             },
+            SyncStateChangedNotification::TrustSync { processed, total} => SyncStateChangedNotificationMessage {
+                sync_state: Some(sync_state_changed_notification_message::SyncState::TrustSync(crate::protowire::TrustSyncState {
+                    processed: *processed,
+                    total: *total
+                }))
+            },
         }
 });