Fees metric reset by block

Author: feliam

Cargo.toml

@@ -12,7 +12,6 @@ clap-verbosity-flag = "2.1.1"
 namada_sdk = { version = "0.47.1", default-features = false, features = ["std", "async-send", "download-params"] }
 tendermint-config = "0.40.1"
 tendermint-rpc = { version = "0.40.1", features = ["http-client"] }
-
 tokio = {version = "1.8.2", default-features = false}
 async-trait = "0.1.74"
 reqwest = { version = "0.11.22", features = ["json"] }
@@ -32,4 +31,3 @@ tokio-retry2 = { version = "0.5", features = ["jitter", "tracing"] }
 
 [build-dependencies]
 vergen = { version = "8.0.0", features = ["build", "git", "gitcl"] }
-

src/config.rs

@@ -23,7 +23,7 @@ pub struct AppConfig {
     #[clap(long, env, default_value_t = u64::MAX)]
     pub last_block_height: u64,
 
-    #[clap(long, env, default_value_t = 500)]
+    #[clap(long, env, default_value_t = 1000)]
     pub sleep_for: u64,
 
     #[clap(flatten)]

src/main.rs

@@ -157,7 +157,7 @@ async fn main() -> anyhow::Result<()> {
 }
 
 fn retry_strategy(max_delay_milis: u64) -> ExponentialBackoff {
-    ExponentialBackoff::from_millis(100)
+    ExponentialBackoff::from_millis(1000)
         .factor(1)
         .max_delay_millis(max_delay_milis)
 }

src/metrics/fees.rs

@@ -32,6 +32,7 @@ impl MetricTrait for Fees {
 
     fn reset(&self, state: &State) {
         let block = state.get_last_block();
+        self.fees.reset();
         for tx in &block.transactions {
             let amount_per_gas = tx.fee.amount_per_gas_unit.parse::<f64>();
             let gas_limit = tx.fee.gas.parse::<f64>();

src/metrics/transfers.rs

@@ -1,6 +1,6 @@
 /// ## Transfer Amount (transfer_amount)
-/// This metric tracks the total amount of tokens transferred per epoch. It helps monitor token movement trends and detect unusual
-///  transfer activity.
+/// This metric tracks the total amount of tokens transferred since the monitoring started.
+/// It helps monitor token movement trends and detect unusual transfer activity.
 ///
 /// ### Example
 /// ```

src/rpc.rs

@@ -168,6 +168,7 @@ impl Rpc {
             .collect();
 
         let events_res = self.concurrent_requests(events_futures).await;
+
         let events = events_res.map(BlockResult::from).context(format!(
             "Should be able to query for block events for height: {}",
             block_height
@@ -387,8 +388,8 @@ impl Rpc {
             let (result, index, remaining) = futures::future::select_all(futures).await;
             match result {
                 Ok(value) => return Some((index, value)),
-                Err(_e) => {
-                    //tracing::error!("Error: {:?}", _e);
+                Err(e) => {
+                    tracing::error!("Error: {:?}", e);
                     futures = remaining
                 }
             }