Add get_by_hashes to aggregator TransactionsRetriever trait

The goal is to use it to retrieves the transactions to prove instead of
walking throught the entire transactions list.

Author: Alenar

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

@@ -29,6 +29,15 @@ impl<'client> GetCardanoTransactionProvider<'client> {
         )
     }
 
+    pub fn get_transaction_hashes_condition(
+        &self,
+        transactions_hashes: Vec<TransactionHash>,
+    ) -> WhereCondition {
+        let hashes_values = transactions_hashes.into_iter().map(Value::String).collect();
+
+        WhereCondition::where_in("transaction_hash", hashes_values)
+    }
+
     pub fn get_transaction_up_to_beacon_condition(
         &self,
         beacon: ImmutableFileNumber,

mithril-aggregator/src/database/repository/cardano_transaction_repository.rs

@@ -159,6 +159,20 @@ impl TransactionsRetriever for CardanoTransactionRepository {
                     .collect::<Vec<CardanoTransaction>>()
             })
     }
+
+    async fn get_by_hashes(
+        &self,
+        hashes: Vec<TransactionHash>,
+    ) -> StdResult<Vec<CardanoTransaction>> {
+        let provider = GetCardanoTransactionProvider::new(&self.connection);
+        let filters = provider.get_transaction_hashes_condition(hashes);
+        let transactions = provider.find(filters)?;
+
+        Ok(transactions
+            .into_iter()
+            .map(|record| record.into())
+            .collect())
+    }
 }
 
 #[cfg(test)]
@@ -193,6 +207,32 @@ mod tests {
         );
     }
 
+    #[tokio::test]
+    async fn repository_get_transaction_by_hashes() {
+        let connection = Arc::new(cardano_tx_db_connection().unwrap());
+        let repository = CardanoTransactionRepository::new(connection);
+        repository
+            .create_transaction("tx-hash-123", 10, 50, "block_hash-123", 99)
+            .await
+            .unwrap();
+        repository
+            .create_transaction("tx-hash-456", 11, 51, "block_hash-456", 100)
+            .await
+            .unwrap();
+        let transactions_result = repository
+            .get_by_hashes(vec!["tx-hash-123".to_string(), "tx-hash-456".to_string()])
+            .await
+            .unwrap();
+
+        assert_eq!(
+            vec![
+                CardanoTransaction::new("tx-hash-123", 10, 50, "block_hash-123", 99),
+                CardanoTransaction::new("tx-hash-456", 11, 51, "block_hash-456", 100),
+            ],
+            transactions_result
+        );
+    }
+
     #[tokio::test]
     async fn repository_create_ignore_further_transactions_when_exists() {
         let connection = Arc::new(cardano_tx_db_connection().unwrap());

mithril-aggregator/src/services/prover.rs

@@ -12,11 +12,8 @@ use mithril_common::{
     StdResult,
 };
 
-#[cfg(test)]
-use mockall::automock;
-
 /// Prover service is the cryptographic engine in charge of producing cryptographic proofs for transactions
-#[cfg_attr(test, automock)]
+#[cfg_attr(test, mockall::automock)]
 #[async_trait]
 pub trait ProverService: Sync + Send {
     /// Compute the cryptographic proofs for the given transactions
@@ -28,11 +25,17 @@ pub trait ProverService: Sync + Send {
 }
 
 /// Transactions retriever
-#[cfg_attr(test, automock)]
+#[cfg_attr(test, mockall::automock)]
 #[async_trait]
 pub trait TransactionsRetriever: Sync + Send {
-    /// Get transactions up to given beacon using chronological order
+    /// Get all transactions up to given beacon using chronological order
     async fn get_up_to(&self, beacon: &CardanoDbBeacon) -> StdResult<Vec<CardanoTransaction>>;
+
+    /// Get a list of transactions by hashes using chronological order
+    async fn get_by_hashes(
+        &self,
+        hashes: Vec<TransactionHash>,
+    ) -> StdResult<Vec<CardanoTransaction>>;
 }
 
 /// Mithril prover