feature: add sending stats for dkg

Author: vid277

crates/node/src/handlers/dkg/handler.rs

@@ -33,7 +33,8 @@ impl<N: Network, W: Wallet> Handler<N, W> for DkgState {
                                 }
                                 Some(DkgInner::Round1Package(_)) => {
                                     dkg_round1_package_metrics!(
-                                        node.network_handle.peer_name(&source_peer)
+                                        node.network_handle.peer_name(&source_peer),
+                                        node.network_handle.peer_name(&node.peer_id)
                                     );
                                     self.handle_round1_payload(node, source_peer, inner_dkg)?;
                                 }
@@ -44,7 +45,10 @@ impl<N: Network, W: Wallet> Handler<N, W> for DkgState {
                 }
             }
             NetworkEvent::MessageEvent((peer, DirectMessage::Round2Package(package))) => {
-                dkg_round2_package_metrics!(node.network_handle.peer_name(&peer));
+                dkg_round2_package_metrics!(
+                    node.network_handle.peer_name(&peer),
+                    node.network_handle.peer_name(&node.peer_id)
+                );
                 self.handle_round2_payload(node, peer, package).await?;
             }
             _ => {}

crates/types/src/macros.rs

@@ -43,14 +43,22 @@ macro_rules! dkg_start_metrics {
 
 #[macro_export]
 macro_rules! dkg_round1_package_metrics {
-    ($peer_from:expr) => {{
-        metrics::counter!("dkg_round1_packages_received", "peer_from" => $peer_from.to_string()).increment(1);
+    ($peer_from:expr, $peer_to:expr) => {{
+        metrics::counter!("dkg_round1_packages_received",
+            "source" => $peer_from.to_string(),
+            "target" => $peer_to.to_string()
+        )
+        .increment(1);
     }};
 }
 
 #[macro_export]
 macro_rules! dkg_round2_package_metrics {
-    ($peer_from:expr) => {{
-        metrics::counter!("dkg_round2_packages_received", "peer_from" => $peer_from.to_string()).increment(1);
+    ($peer_from:expr, $peer_to:expr) => {{
+        metrics::counter!("dkg_round2_packages_received",
+            "source" => $peer_from.to_string(),
+            "target" => $peer_to.to_string()
+        )
+        .increment(1);
     }};
 }