Temp commit

input-output-hk · May 26, 2023 · 404d213 · 404d213
1 parent f366b49
commit 404d213
Show file tree

Hide file tree

Showing 3 changed files with 7 additions and 8 deletions.
diff --git a/.github/workflows/ci.yml b/.github/workflows/ci.yml
@@ -188,7 +188,7 @@ jobs:
       fail-fast: false
       matrix:
         era: ${{ fromJSON(needs.build-ubuntu-X64.outputs.eras) }}
-        run_id: [1,2,3]
+        run_id: [1,2,3,4,5,6,7,8,9,10]
     steps:
       - name: Checkout sources
         uses: actions/checkout@v3

diff --git a/mithril-aggregator/src/certifier_service.rs b/mithril-aggregator/src/certifier_service.rs
@@ -225,10 +225,13 @@ impl CertifierService for MithrilCertifierService {
         protocol_message: &ProtocolMessage,
     ) -> StdResult<OpenMessage> {
         debug!("CertifierService::create_open_message(signed_entity_type: {signed_entity_type:?}, protocol_message: {protocol_message:?})");
-        let current_epoch = self.current_epoch.read().await;
         let open_message = self
             .open_message_repository
-            .create_open_message(*current_epoch, signed_entity_type, protocol_message)
+            .create_open_message(
+                signed_entity_type.get_epoch(),
+                signed_entity_type,
+                protocol_message,
+            )
             .await?;
         info!("CertifierService::create_open_message: created open message for {signed_entity_type:?}");
         debug!(

diff --git a/mithril-signer/src/runtime/runner.rs b/mithril-signer/src/runtime/runner.rs
@@ -366,11 +366,7 @@ impl Runner for SignerRunner {
             .await?;
 
         // 2 set the next signers keys and stakes in the message
-        let epoch = match signed_entity_type {
-            SignedEntityType::MithrilStakeDistribution(epoch) => epoch,
-            SignedEntityType::CardanoImmutableFilesFull(beacon) => &beacon.epoch,
-            SignedEntityType::CardanoStakeDistribution(epoch) => epoch,
-        };
+        let epoch = signed_entity_type.get_epoch();
         let next_signer_retrieval_epoch = epoch.offset_to_next_signer_retrieval_epoch();
         let next_protocol_initializer = self
             .services