feature(aggregator): inform_epoch is now reading data from network_configuration_provider, and persist signer resigration epoch configuration

Author: turmelclem

mithril-aggregator/src/dependency_injection/builder/enablers/epoch.rs

@@ -1,8 +1,9 @@
-use mithril_protocol_config::http_client::http_impl::HttpMithrilNetworkConfigurationProvider;
 use std::sync::Arc;
 use tokio::sync::RwLock;
 
-use mithril_protocol_config::interface::MithrilNetworkConfigurationProvider;
+use mithril_protocol_config::{
+    http::HttpMithrilNetworkConfigurationProvider, interface::MithrilNetworkConfigurationProvider,
+};
 
 use crate::dependency_injection::{DependenciesBuilder, EpochServiceWrapper, Result};
 use crate::get_dependency;
@@ -22,8 +23,8 @@ impl DependenciesBuilder {
             .compute_allowed_signed_entity_types_discriminants()?;
 
         let epoch_service = Arc::new(RwLock::new(MithrilEpochService::new(
-            self.get_mithril_network_configuration_provider().await?,
             EpochServiceDependencies::new(
+                self.get_mithril_network_configuration_provider().await?,
                 epoch_settings_storer,
                 verification_key_store,
                 chain_observer,
@@ -59,6 +60,8 @@ impl DependenciesBuilder {
                 ))
             };
 
+        //TODO handle discrepency here
+
         Ok(network_configuration_provider)
     }
 
@@ -69,17 +72,3 @@ impl DependenciesBuilder {
         get_dependency!(self.mithril_network_configuration_provider)
     }
 }
-
-// Todo remove after rebase with shared aggregator client:
-#[async_trait::async_trait]
-impl mithril_protocol_config::http_client::http_impl::ProtocolConfigurationRetrieverFromAggregator
-    for crate::services::AggregatorHTTPClient
-{
-    /// Retrieves protocol configuration for a given epoch from the aggregator
-    async fn retrieve_protocol_configuration(
-        &self,
-        _epoch: mithril_common::entities::Epoch,
-    ) -> mithril_common::StdResult<mithril_common::messages::ProtocolConfigurationMessage> {
-        unimplemented!()
-    }
-}

mithril-aggregator/src/entities/aggregator_epoch_settings.rs

@@ -9,3 +9,31 @@ pub struct AggregatorEpochSettings {
     /// Cardano transactions signing configuration
     pub cardano_transactions_signing_config: CardanoTransactionsSigningConfig,
 }
+
+#[cfg(test)]
+mod test_utils {
+    use std::collections::BTreeSet;
+
+    use mithril_common::entities::SignedEntityTypeDiscriminants;
+    use mithril_protocol_config::model::{
+        MithrilNetworkConfigurationForEpoch, SignedEntityTypeConfiguration,
+    };
+
+    use super::*;
+
+    impl AggregatorEpochSettings {
+        /// Convert this epoch setting into a [MithrilNetworkConfigurationForEpoch]
+        pub fn into_network_configuration_for_epoch(
+            self,
+            enabled_signed_entity_types: BTreeSet<SignedEntityTypeDiscriminants>,
+        ) -> MithrilNetworkConfigurationForEpoch {
+            MithrilNetworkConfigurationForEpoch {
+                protocol_parameters: self.protocol_parameters,
+                enabled_signed_entity_types,
+                signed_entity_types_config: SignedEntityTypeConfiguration {
+                    cardano_transactions: Some(self.cardano_transactions_signing_config),
+                },
+            }
+        }
+    }
+}