feat: store current_cardano_transactions_signing_config in signer epoch service

Author: dlachaume

mithril-common/src/entities/epoch_settings.rs

@@ -1,4 +1,4 @@
-use crate::entities::{Epoch, ProtocolParameters};
+use crate::entities::{CardanoTransactionsSigningConfig, Epoch, ProtocolParameters};
 
 use super::Signer;
 
@@ -19,4 +19,7 @@ pub struct EpochSettings {
 
     /// Signers that will be able to sign on the next epoch
     pub next_signers: Vec<Signer>,
+
+    /// Cardano transactions signing configuration for the current epoch
+    pub current_cardano_transactions_signing_config: Option<CardanoTransactionsSigningConfig>,
 }

mithril-common/src/messages/epoch_settings.rs

@@ -45,7 +45,7 @@ impl EpochSettingsMessage {
                 },
                 current_signers: [SignerMessagePart::dummy()].to_vec(),
                 next_signers: [SignerMessagePart::dummy()].to_vec(),
-                current_cardano_transactions_signing_config: None,
+                current_cardano_transactions_signing_config: Some(CardanoTransactionsSigningConfig::dummy()),
             }
         }
     }

mithril-common/src/test_utils/fake_data.rs

@@ -66,13 +66,18 @@ pub fn epoch_settings() -> entities::EpochSettings {
     let current_signers = signers[1..3].to_vec();
     let next_signers = signers[2..5].to_vec();
 
+    // Cardano transactions signing configuration for the current epoch
+    let current_cardano_transactions_signing_config =
+        Some(entities::CardanoTransactionsSigningConfig::dummy());
+
     // Epoch settings
     entities::EpochSettings {
         epoch: beacon.epoch,
         protocol_parameters,
         next_protocol_parameters,
         current_signers,
         next_signers,
+        current_cardano_transactions_signing_config,
     }
 }
 

mithril-signer/src/message_adapters/from_epoch_settings.rs

@@ -19,6 +19,8 @@ impl TryFromMessageAdapter<EpochSettingsMessage, EpochSettings> for FromEpochSet
                 .with_context(|| "'FromMessageAdapter' can not convert the current signers")?,
             next_signers: SignerMessagePart::try_into_signers(message.next_signers)
                 .with_context(|| "'FromMessageAdapter' can not convert the next signers")?,
+            current_cardano_transactions_signing_config: message
+                .current_cardano_transactions_signing_config,
         };
         Ok(epoch_settings)
     }

mithril-signer/src/runtime/runner.rs

@@ -458,7 +458,10 @@ mod tests {
             MKMap, MKMapNode, MKTreeNode, MKTreeStoreInMemory, MKTreeStorer, ProtocolInitializer,
         },
         digesters::{DumbImmutableDigester, DumbImmutableFileObserver},
-        entities::{BlockNumber, BlockRange, CardanoDbBeacon, Epoch, ProtocolParameters},
+        entities::{
+            BlockNumber, BlockRange, CardanoDbBeacon, CardanoTransactionsSigningConfig, Epoch,
+            ProtocolParameters,
+        },
         era::{adapters::EraReaderBootstrapAdapter, EraChecker, EraReader},
         signable_builder::{
             BlockRangeRootRetriever, CardanoImmutableFilesFullSignableBuilder,
@@ -545,6 +548,11 @@ mod tests {
         async fn next_signers_with_stake(&self) -> StdResult<Vec<SignerWithStake>> {
             Ok(vec![])
         }
+        fn current_cardano_transactions_signing_config(
+            &self,
+        ) -> StdResult<&Option<CardanoTransactionsSigningConfig>> {
+            Ok(&None)
+        }
 
         fn is_signer_included_in_current_stake_distribution(
             &self,

mithril-signer/src/runtime/state_machine.rs

@@ -548,6 +548,7 @@ mod tests {
             next_protocol_parameters: fake_data::protocol_parameters(),
             current_signers: vec![],
             next_signers: vec![],
+            current_cardano_transactions_signing_config: None,
         };
         let known_epoch = Epoch(4);
         runner

mithril-signer/src/services/epoch_service.rs

@@ -2,6 +2,7 @@ use std::sync::Arc;
 
 use async_trait::async_trait;
 use mithril_common::crypto_helper::ProtocolInitializer;
+use mithril_common::entities::CardanoTransactionsSigningConfig;
 use mithril_common::entities::Epoch;
 use mithril_common::entities::PartyId;
 use mithril_common::entities::ProtocolParameters;
@@ -49,6 +50,11 @@ pub trait EpochService: Sync + Send {
     /// Get signers with stake for the next epoch
     async fn next_signers_with_stake(&self) -> StdResult<Vec<SignerWithStake>>;
 
+    /// Get the cardano transactions signing configuration for the current epoch
+    fn current_cardano_transactions_signing_config(
+        &self,
+    ) -> StdResult<&Option<CardanoTransactionsSigningConfig>>;
+
     /// Check if a signer is included in the current stake distribution
     fn is_signer_included_in_current_stake_distribution(
         &self,
@@ -62,6 +68,7 @@ struct EpochData {
     next_protocol_parameters: ProtocolParameters,
     current_signers: Vec<Signer>,
     next_signers: Vec<Signer>,
+    current_cardano_transactions_signing_config: Option<CardanoTransactionsSigningConfig>,
 }
 
 /// Implementation of the [epoch service][EpochService].
@@ -138,6 +145,8 @@ impl EpochService for MithrilEpochService {
             next_protocol_parameters: epoch_settings.next_protocol_parameters,
             current_signers: epoch_settings.current_signers,
             next_signers: epoch_settings.next_signers,
+            current_cardano_transactions_signing_config: epoch_settings
+                .current_cardano_transactions_signing_config,
         });
 
         Ok(())
@@ -177,6 +186,14 @@ impl EpochService for MithrilEpochService {
         .await
     }
 
+    fn current_cardano_transactions_signing_config(
+        &self,
+    ) -> StdResult<&Option<CardanoTransactionsSigningConfig>> {
+        Ok(&self
+            .unwrap_data()?
+            .current_cardano_transactions_signing_config)
+    }
+
     fn is_signer_included_in_current_stake_distribution(
         &self,
         party_id: PartyId,
@@ -302,6 +319,9 @@ mod tests {
         assert!(service.next_signers().is_err());
         assert!(service.current_signers_with_stake().await.is_err());
         assert!(service.next_signers_with_stake().await.is_err());
+        assert!(service
+            .current_cardano_transactions_signing_config()
+            .is_err());
     }
 
     #[test]
@@ -350,6 +370,14 @@ mod tests {
             epoch_settings.next_protocol_parameters,
             *service.next_protocol_parameters().unwrap()
         );
+
+        // Check current_cardano_transactions_signing_config
+        assert_eq!(
+            epoch_settings.current_cardano_transactions_signing_config,
+            *service
+                .current_cardano_transactions_signing_config()
+                .unwrap()
+        )
     }
 
     #[tokio::test]