Add Era checker dependency in signer

Author: jpraynaud

mithril-signer/src/runtime/runner.rs

@@ -438,6 +438,7 @@ mod tests {
         crypto_helper::ProtocolInitializer,
         digesters::{DumbImmutableDigester, DumbImmutableFileObserver},
         entities::{Epoch, StakeDistribution},
+        era::{EraChecker, SupportedEra},
         store::{
             adapter::{DumbStoreAdapter, MemoryAdapter},
             StakeStore, StakeStorer,
@@ -469,6 +470,7 @@ mod tests {
     fn init_services() -> SignerServices {
         let adapter: MemoryAdapter<Epoch, ProtocolInitializer> = MemoryAdapter::new(None).unwrap();
         let chain_observer = Arc::new(FakeObserver::default());
+        let era_checker = Arc::new(EraChecker::new(SupportedEra::dummy()));
         SignerServices {
             stake_store: Arc::new(StakeStore::new(Box::new(DumbStoreAdapter::new()), None)),
             certificate_handler: Arc::new(DumbCertificateHandler::default()),
@@ -484,6 +486,7 @@ mod tests {
                 Box::new(adapter),
                 None,
             )),
+            era_checker,
         }
     }
 

mithril-signer/src/runtime/signer_services.rs

@@ -5,16 +5,20 @@ use std::{
     sync::Arc,
 };
 
-use mithril_common::digesters::cache::{
-    ImmutableFileDigestCacheProvider, JsonImmutableFileDigestCacheProviderBuilder,
-};
 use mithril_common::{
     chain_observer::{CardanoCliChainObserver, CardanoCliRunner, ChainObserver},
     crypto_helper::{OpCert, ProtocolPartyId, SerDeShelleyFileFormat},
     digesters::{CardanoImmutableDigester, ImmutableDigester, ImmutableFileSystemObserver},
+    era::EraChecker,
     store::{adapter::SQLiteAdapter, StakeStore},
     BeaconProvider, BeaconProviderImpl,
 };
+use mithril_common::{
+    digesters::cache::{
+        ImmutableFileDigestCacheProvider, JsonImmutableFileDigestCacheProviderBuilder,
+    },
+    era::SupportedEra,
+};
 
 use crate::{
     certificate_handler::CertificateHandler, single_signer::SingleSigner,
@@ -128,6 +132,9 @@ impl<'a> ServiceBuilder for ProductionServiceBuilder<'a> {
             Arc::new(ImmutableFileSystemObserver::new(&self.config.db_directory)),
             self.config.get_network()?.to_owned(),
         ));
+        // TODO: use EraReader when it is implemented to retrieve current era
+        let current_era = SupportedEra::Thales;
+        let era_checker = Arc::new(EraChecker::new(current_era));
 
         let services = SignerServices {
             beacon_provider,
@@ -137,6 +144,7 @@ impl<'a> ServiceBuilder for ProductionServiceBuilder<'a> {
             single_signer,
             stake_store,
             protocol_initializer_store,
+            era_checker,
         };
 
         Ok(services)
@@ -165,6 +173,9 @@ pub struct SignerServices {
 
     /// ProtocolInitializer store
     pub protocol_initializer_store: ProtocolInitializerStoreService,
+
+    /// Era checker service
+    pub era_checker: Arc<EraChecker>,
 }
 
 #[cfg(test)]

mithril-signer/tests/test_extensions/state_machine_tester.rs

@@ -1,5 +1,6 @@
 use mithril_common::digesters::ImmutableFileObserver;
 use mithril_common::entities::SignerWithStake;
+use mithril_common::era::{EraChecker, SupportedEra};
 use slog::Drain;
 use slog_scope::debug;
 use std::error::Error as StdError;
@@ -104,6 +105,7 @@ impl StateMachineTester {
             Box::new(MemoryAdapter::new(None).unwrap()),
             config.store_retention_limit,
         ));
+        let era_checker = Arc::new(EraChecker::new(SupportedEra::dummy()));
 
         let services = SignerServices {
             certificate_handler: certificate_handler.clone(),
@@ -113,6 +115,7 @@ impl StateMachineTester {
             protocol_initializer_store: protocol_initializer_store.clone(),
             single_signer: single_signer.clone(),
             stake_store: stake_store.clone(),
+            era_checker,
         };
         // set up stake distribution
         chain_observer