additional datapoint_error

Author: gzalz

tip-router-operator-cli/src/process_epoch.rs

@@ -119,6 +119,13 @@ pub async fn loop_stages(
                 Ok(info) => break info,
                 Err(e) => {
                     error!("Error getting epoch info from RPC. Retrying...");
+                    datapoint_error!(
+                        "tip_router_cli.get_epoch_info",
+                        ("operator_address", cli.operator_address.clone(), String),
+                        ("status", "error", String),
+                        ("error", e.to_string(), String),
+                        "cluster" => &cli.cluster,
+                    );
                     tokio::time::sleep(Duration::from_secs(5)).await;
                 }
             }
@@ -131,6 +138,13 @@ pub async fn loop_stages(
                 Ok(schedule) => break schedule,
                 Err(e) => {
                     error!("Error getting epoch schedule from RPC. Retrying...");
+                    datapoint_error!(
+                        "tip_router_cli.get_epoch_schedule",
+                        ("operator_address", cli.operator_address.clone(), String),
+                        ("status", "error", String),
+                        ("error", e.to_string(), String),
+                        "cluster" => &cli.cluster,
+                    );
                     tokio::time::sleep(Duration::from_secs(5)).await;
                 }
             }
@@ -333,6 +347,15 @@ pub async fn loop_stages(
                         "Failed to submit epoch {} to NCN: {:?}",
                         epoch_to_process, e
                     );
+                    datapoint_error!(
+                        "tip_router_cli.cast_vote",
+                        ("operator_address", operator_address.to_string(), String),
+                        ("epoch", epoch_to_process, i64),
+                        ("status", "error", String),
+                        ("error", e.to_string(), String),
+                        ("state", "cast_vote", String),
+                        "cluster" => &cli.cluster,
+                    );
                 }
                 stage = OperatorState::WaitForNextEpoch;
             }

tip-router-operator-cli/src/submit.rs

@@ -136,15 +136,35 @@ pub async fn submit_to_ncn(
         }
     };
 
-    let ballot_box = BallotBox::try_from_slice_unchecked(&ballot_box_account.data)
-        .map_err(|e| anyhow::anyhow!("Failed to deserialize ballot box: {:?}", e))?;
+    let ballot_box =
+        BallotBox::try_from_slice_unchecked(&ballot_box_account.data).map_err(|e| {
+            datapoint_error!(
+                "tip_router_cli.ballot_box_deserialize_error",
+                ("operator_address", operator_address.to_string(), String),
+                ("epoch", tip_router_target_epoch, i64),
+                ("status", "error", String),
+                ("error", format!("{:?}", e), String),
+                "cluster" => cluster,
+            );
+            anyhow::anyhow!("Failed to deserialize ballot box: {:?}", e)
+        })?;
 
     let is_voting_valid = ballot_box
         .is_voting_valid(
             epoch_info.absolute_slot,
             config.valid_slots_after_consensus(),
         )
-        .map_err(|e| anyhow::anyhow!("Failed to determine if voting is valid: {:?}", e))?;
+        .map_err(|e| {
+            datapoint_error!(
+                "tip_router_cli.voting_validity_error",
+                ("operator_address", operator_address.to_string(), String),
+                ("epoch", tip_router_target_epoch, i64),
+                ("status", "error", String),
+                ("error", format!("{:?}", e), String),
+                "cluster" => cluster,
+            );
+            anyhow::anyhow!("Failed to determine if voting is valid: {:?}", e)
+        })?;
 
     // If exists, look for vote from current operator
     let vote = ballot_box