ensure we can get latest timestamp

Concordium · Sep 17, 2024 · ac5bd3a · ac5bd3a
1 parent 9f443d9
commit ac5bd3a
Show file tree

Hide file tree

Showing 3 changed files with 8 additions and 2 deletions.
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
@@ -22,6 +22,8 @@ use std::{
     path::PathBuf,
     time::{Duration, Instant},
 };
+use std::time::{SystemTime, UNIX_EPOCH};
+use axum_prometheus::metrics::gauge;
 use tonic::{codegen::http, transport::ClientTlsConfig};
 use tracing_subscriber::{layer::SubscriberExt, util::SubscriberInitExt};
 
@@ -329,6 +331,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);