Make all signer & aggregator provider method pub if they were pub(crate)

As the pub(crate) visibility modifier is enforced for the whole
`provider` module on the database::mod file.

Author: Alenar

mithril-aggregator/src/database/provider/cardano_transaction/get_cardano_transaction.rs

@@ -19,7 +19,7 @@ impl<'client> GetCardanoTransactionProvider<'client> {
     }
 
     // Useful in test and probably in the future.
-    pub(crate) fn get_transaction_hash_condition(
+    pub fn get_transaction_hash_condition(
         &self,
         transaction_hash: &TransactionHash,
     ) -> WhereCondition {
@@ -29,7 +29,7 @@ impl<'client> GetCardanoTransactionProvider<'client> {
         )
     }
 
-    pub(crate) fn get_transaction_up_to_beacon_condition(
+    pub fn get_transaction_up_to_beacon_condition(
         &self,
         beacon: ImmutableFileNumber,
     ) -> WhereCondition {

mithril-aggregator/src/database/provider/open_message/delete_open_message.rs

@@ -18,7 +18,7 @@ impl<'client> DeleteOpenMessageProvider<'client> {
         Self { connection }
     }
 
-    pub(crate) fn get_epoch_condition(&self, epoch: Epoch) -> WhereCondition {
+    pub fn get_epoch_condition(&self, epoch: Epoch) -> WhereCondition {
         WhereCondition::new("epoch_setting_id < ?*", vec![Value::Integer(*epoch as i64)])
     }
 }

mithril-aggregator/src/database/provider/open_message/get_open_message.rs

@@ -21,11 +21,11 @@ impl<'client> GetOpenMessageProvider<'client> {
         Self { connection }
     }
 
-    pub(crate) fn get_epoch_condition(&self, epoch: Epoch) -> WhereCondition {
+    pub fn get_epoch_condition(&self, epoch: Epoch) -> WhereCondition {
         WhereCondition::new("epoch_setting_id = ?*", vec![Value::Integer(*epoch as i64)])
     }
 
-    pub(crate) fn get_signed_entity_type_condition(
+    pub fn get_signed_entity_type_condition(
         &self,
         signed_entity_type: &SignedEntityType,
     ) -> StdResult<WhereCondition> {
@@ -38,7 +38,7 @@ impl<'client> GetOpenMessageProvider<'client> {
         ))
     }
 
-    pub(crate) fn get_expired_entity_type_condition(&self, now: &str) -> WhereCondition {
+    pub fn get_expired_entity_type_condition(&self, now: &str) -> WhereCondition {
         WhereCondition::new("expires_at < ?*", vec![Value::String(now.to_string())])
     }
 

mithril-aggregator/src/database/provider/open_message/get_open_message_with_single_signatures.rs

@@ -18,11 +18,11 @@ impl<'client> GetOpenMessageWithSingleSignaturesProvider<'client> {
         Self { connection }
     }
 
-    pub(crate) fn get_epoch_condition(&self, epoch: Epoch) -> WhereCondition {
+    pub fn get_epoch_condition(&self, epoch: Epoch) -> WhereCondition {
         WhereCondition::new("epoch_setting_id = ?*", vec![Value::Integer(*epoch as i64)])
     }
 
-    pub(crate) fn get_signed_entity_type_condition(
+    pub fn get_signed_entity_type_condition(
         &self,
         signed_entity_type: &SignedEntityType,
     ) -> StdResult<WhereCondition> {

mithril-aggregator/src/database/provider/open_message/insert_open_message.rs

@@ -21,7 +21,7 @@ impl<'client> InsertOpenMessageProvider<'client> {
         Self { connection }
     }
 
-    pub(crate) fn get_insert_condition(
+    pub fn get_insert_condition(
         &self,
         epoch: Epoch,
         signed_entity_type: &SignedEntityType,

mithril-aggregator/src/database/provider/open_message/update_open_message.rs

@@ -19,7 +19,7 @@ impl<'client> UpdateOpenMessageProvider<'client> {
         Self { connection }
     }
 
-    pub(crate) fn get_update_condition(
+    pub fn get_update_condition(
         &self,
         open_message: &OpenMessageRecord,
     ) -> StdResult<WhereCondition> {

mithril-aggregator/src/database/provider/signed_entity/insert_signed_entity.rs

@@ -18,10 +18,7 @@ impl<'conn> InsertSignedEntityRecordProvider<'conn> {
         Self { connection }
     }
 
-    pub(crate) fn get_insert_condition(
-        &self,
-        signed_entity_record: SignedEntityRecord,
-    ) -> WhereCondition {
+    pub fn get_insert_condition(&self, signed_entity_record: SignedEntityRecord) -> WhereCondition {
         WhereCondition::new(
             "(signed_entity_id, signed_entity_type_id, certificate_id, beacon, artifact, created_at) values (?*, ?*, ?*, ?*, ?*, ?*)",
             vec![
@@ -35,7 +32,7 @@ impl<'conn> InsertSignedEntityRecordProvider<'conn> {
         )
     }
 
-    pub(crate) fn persist(
+    pub fn persist(
         &self,
         signed_entity_record: SignedEntityRecord,
     ) -> StdResult<SignedEntityRecord> {

mithril-aggregator/src/database/provider/signed_entity/update_signed_entity.rs

@@ -38,7 +38,7 @@ where signed_entity_id = ?*";
         Ok(WhereCondition::new(expression, parameters))
     }
 
-    pub(crate) fn persist(
+    pub fn persist(
         &self,
         signed_entity_record: &SignedEntityRecord,
     ) -> StdResult<SignedEntityRecord> {

mithril-aggregator/src/database/provider/signer/import_signer.rs

@@ -23,7 +23,7 @@ impl<'conn> ImportSignerRecordProvider<'conn> {
         Self { connection }
     }
 
-    pub(crate) fn get_import_condition(&self, signer_records: Vec<SignerRecord>) -> WhereCondition {
+    pub fn get_import_condition(&self, signer_records: Vec<SignerRecord>) -> WhereCondition {
         let columns = "(signer_id, pool_ticker, created_at, updated_at, last_registered_at)";
         let values_columns: Vec<&str> = repeat("(?*, ?*, ?*, ?*, ?*)")
             .take(signer_records.len())
@@ -53,7 +53,7 @@ impl<'conn> ImportSignerRecordProvider<'conn> {
         )
     }
 
-    pub(crate) fn persist(&self, signer_record: SignerRecord) -> StdResult<SignerRecord> {
+    pub fn persist(&self, signer_record: SignerRecord) -> StdResult<SignerRecord> {
         let filters = self.get_import_condition(vec![signer_record.clone()]);
 
         let entity = self.find(filters)?.next().unwrap_or_else(|| {
@@ -63,10 +63,7 @@ impl<'conn> ImportSignerRecordProvider<'conn> {
         Ok(entity)
     }
 
-    pub(crate) fn persist_many(
-        &self,
-        signer_records: Vec<SignerRecord>,
-    ) -> StdResult<Vec<SignerRecord>> {
+    pub fn persist_many(&self, signer_records: Vec<SignerRecord>) -> StdResult<Vec<SignerRecord>> {
         let filters = self.get_import_condition(signer_records);
 
         Ok(self.find(filters)?.collect())

mithril-aggregator/src/database/provider/signer/register_signer.rs

@@ -39,7 +39,7 @@ impl<'conn> RegisterSignerRecordProvider<'conn> {
         )
     }
 
-    pub(crate) fn persist(&self, signer_record: SignerRecord) -> StdResult<SignerRecord> {
+    pub fn persist(&self, signer_record: SignerRecord) -> StdResult<SignerRecord> {
         let filters = self.get_register_condition(signer_record.clone());
 
         let entity = self.find(filters)?.next().unwrap_or_else(|| {