Merge pull request #812 from input-output-hk/jpraynaud/727-handle-api-era-switch

Handle API version with Era Switch

Author: jpraynaud

Cargo.lock

@@ -1,6 +1,6 @@
 [package]
 name = "mithril-aggregator"
-version = "0.2.32"
+version = "0.2.33"
 description = "A Mithril Aggregator server"
 authors = { workspace = true }
 edition = { workspace = true }

mithril-aggregator/Cargo.toml

@@ -18,6 +18,7 @@ use tokio::{
 };
 
 use mithril_common::{
+    api_version::APIVersionProvider,
     certificate_chain::MithrilCertificateVerifier,
     chain_observer::{CardanoCliRunner, ChainObserver},
     crypto_helper::{
@@ -446,6 +447,8 @@ impl ServeCommand {
         let event_transmitter = Arc::new(TransmitterService::new(tx));
         let mut event_store = event_store::EventStore::new(rx);
 
+        let api_version_provider = Arc::new(APIVersionProvider::new(era_checker.clone()));
+
         // Init dependency manager
         let dependency_manager = DependencyManager {
             config: config.clone(),
@@ -470,6 +473,7 @@ impl ServeCommand {
             era_checker: era_checker.clone(),
             era_reader: era_reader.clone(),
             event_transmitter,
+            api_version_provider,
         };
         let dependency_manager = Arc::new(dependency_manager);
 

mithril-aggregator/src/command_args.rs

@@ -1,4 +1,5 @@
 use mithril_common::{
+    api_version::APIVersionProvider,
     certificate_chain::CertificateVerifier,
     chain_observer::ChainObserver,
     crypto_helper::ProtocolGenesisVerifier,
@@ -93,6 +94,9 @@ pub struct DependencyManager {
 
     /// Event Transmitter Service
     pub event_transmitter: Arc<TransmitterService<EventMessage>>,
+
+    /// API Version provider
+    pub api_version_provider: Arc<APIVersionProvider>,
 }
 
 #[doc(hidden)]
@@ -271,6 +275,7 @@ pub mod tests {
         SingleSignatureStore, SnapshotUploaderType, VerificationKeyStore,
     };
     use mithril_common::{
+        api_version::APIVersionProvider,
         certificate_chain::MithrilCertificateVerifier,
         chain_observer::FakeObserver,
         crypto_helper::{key_encode_hex, ProtocolGenesisSigner},
@@ -374,6 +379,8 @@ pub mod tests {
             Arc::new(TransmitterService::new(tx))
         };
 
+        let api_version_provider = Arc::new(APIVersionProvider::new(era_checker.clone()));
+
         let dependency_manager = DependencyManager {
             config,
             snapshot_store,
@@ -397,6 +404,7 @@ pub mod tests {
             era_checker,
             era_reader,
             event_transmitter,
+            api_version_provider,
         };
 
         let config = AggregatorConfig::new(