Ensure we can get latest timestamp (#226)

* ensure we can get latest timestamp * ensure latest traversel added * fmt * Update notification-server/CHANGELOG.md Co-authored-by: Søren Bruus Zeppelin <[email protected]> --------- Co-authored-by: Søren Bruus Zeppelin <[email protected]>
Concordium · Sep 18, 2024 · 84263e0 · 84263e0
1 parent 9f443d9
commit 84263e0
Show file tree

Hide file tree

Showing 4 changed files with 12 additions and 5 deletions.
diff --git a/notification-server/CHANGELOG.md b/notification-server/CHANGELOG.md
@@ -1,6 +1,9 @@
+## 0.3.3
+- Add timestamp for when a block was last processed to tracked metrics
+
 ## 0.3.2
 - Initiate prepared statements from within each function call
-- 
+
 ## 0.3.1
 - No longer use aspn specific information
 

diff --git a/notification-server/Cargo.lock b/notification-server/Cargo.lock
diff --git a/notification-server/Cargo.toml b/notification-server/Cargo.toml
@@ -2,7 +2,7 @@
 authors = ["Concordium AG [email protected]"]
 edition = "2021"
 name = "notification-server"
-version = "0.3.2"
+version = "0.3.3"
 
 # See more keys and their definitions at https://doc.rust-lang.org/cargo/reference/manifest.html
 

diff --git a/notification-server/src/bin/service.rs b/notification-server/src/bin/service.rs
@@ -1,6 +1,6 @@
 use anyhow::{anyhow, Context};
 use axum_prometheus::{
-    metrics::{counter, histogram},
+    metrics::{counter, gauge, histogram},
     metrics_exporter_prometheus::PrometheusBuilder,
 };
 use backoff::{future::retry, ExponentialBackoff};
@@ -20,7 +20,7 @@ use notification_server::{
 };
 use std::{
     path::PathBuf,
-    time::{Duration, Instant},
+    time::{Duration, Instant, SystemTime, UNIX_EPOCH},
 };
 use tonic::{codegen::http, transport::ClientTlsConfig};
 use tracing_subscriber::{layer::SubscriberExt, util::SubscriberInitExt};
@@ -329,6 +329,10 @@ async fn traverse_chain(
                 processed_height = block_height;
                 let delta = start.elapsed();
                 histogram!("block.process_successful_duration").record(delta);
+                if let Ok(duration_since_epoch) = SystemTime::now().duration_since(UNIX_EPOCH) {
+                    let current_timestamp = duration_since_epoch.as_secs() as f64;
+                    gauge!("block.process_successful_last_unix").set(current_timestamp);
+                }
             }
             Err(err) => {
                 error!("Error occurred while processing block: {:?}", err);