chore: adding storage context on startup

crates/topos-tce-storage/src/fullnode/mod.rs

@@ -227,6 +227,10 @@ impl WriteStore for FullNodeStore {
 }
 
 impl ReadStore for FullNodeStore {
+    fn count_certificates_delivered(&self) -> Result<usize, StorageError> {
+        Ok(self.perpetual_tables.certificates.iter()?.count())
+    }
+
     fn get_source_head(&self, subnet_id: &SubnetId) -> Result<Option<SourceHead>, StorageError> {
         Ok(self
             .index_tables

crates/topos-tce-storage/src/store.rs

@@ -42,6 +42,9 @@ pub trait WriteStore: Send {
 /// [`ValidatorStore`](struct@super::validator::ValidatorStore) and
 /// [`FullNodeStore`](struct@super::fullnode::FullNodeStore) to read data.
 pub trait ReadStore: Send {
+    /// Returns the number of certificates delivered
+    fn count_certificates_delivered(&self) -> Result<usize, StorageError>;
+
     /// Try to get a SourceHead of a subnet
     ///
     /// Returns `Ok(None)` if the subnet is not found, meaning that no certificate are currently

crates/topos-tce-storage/src/validator/mod.rs

@@ -86,6 +86,11 @@ impl ValidatorStore {
         Ok(self.pending_tables.pending_pool.iter()?.count())
     }
 
+    /// Returns the number of certificates in the precedence pool
+    pub fn count_precedence_pool_certificates(&self) -> Result<usize, StorageError> {
+        Ok(self.pending_tables.precedence_pool.iter()?.count())
+    }
+
     /// Try to return the [`PendingCertificateId`] for a [`CertificateId`]
     ///
     /// Return `Ok(None)` if the `certificate_id` is not found.
@@ -375,6 +380,10 @@ impl ValidatorStore {
     }
 }
 impl ReadStore for ValidatorStore {
+    fn count_certificates_delivered(&self) -> Result<usize, StorageError> {
+        self.fullnode_store.count_certificates_delivered()
+    }
+
     fn get_source_head(&self, subnet_id: &SubnetId) -> Result<Option<SourceHead>, StorageError> {
         self.fullnode_store.get_source_head(subnet_id)
     }

crates/topos-tce/src/lib.rs

@@ -3,6 +3,7 @@ use futures::StreamExt;
 use opentelemetry::global;
 use std::{
     future::IntoFuture,
+    panic::UnwindSafe,
     sync::{atomic::AtomicBool, Arc},
 };
 use tokio::{
@@ -22,11 +23,12 @@ use topos_tce_storage::{
     epoch::{EpochValidatorsStore, ValidatorPerEpochStore},
     fullnode::FullNodeStore,
     index::IndexTables,
+    store::ReadStore,
     validator::{ValidatorPerpetualTables, ValidatorStore},
     StorageClient,
 };
 use topos_tce_synchronizer::SynchronizerService;
-use tracing::{debug, warn};
+use tracing::{debug, info, warn};
 
 mod app_context;
 pub mod config;
@@ -117,6 +119,27 @@ pub async fn run(
         ),
     );
 
+    let certificates_synced = fullnode_store
+        .count_certificates_delivered()
+        .map_err(|error| format!("Unable to count certificates delivered: {error}"))
+        .unwrap();
+
+    let pending_certificates = validator_store
+        .count_pending_certificates()
+        .map_err(|error| format!("Unable to count pending certificates: {error}"))
+        .unwrap();
+
+    let precedence_pool_certificates = validator_store
+        .count_precedence_pool_certificates()
+        .map_err(|error| format!("Unable to count precedence pool certificates: {error}"))
+        .unwrap();
+
+    info!(
+        "Storage initialized with {} certificates delivered, {} pending certificates and {} \
+         certificates in the precedence pool",
+        certificates_synced, pending_certificates, precedence_pool_certificates
+    );
+
     let (network_client, event_stream, unbootstrapped_runtime) = topos_p2p::network::builder()
         .peer_key(key)
         .listen_addr(addr)