|
| 1 | +use std::ops::RangeInclusive; |
1 | 2 | use std::path::{Path, PathBuf};
|
2 | 3 | use std::sync::Arc;
|
3 | 4 |
|
@@ -25,8 +26,7 @@ pub trait TransactionStore: Send + Sync {
|
25 | 26 | /// Get transactions between two block numbers
|
26 | 27 | async fn get_transactions_between(
|
27 | 28 | &self,
|
28 |
| - start: BlockNumber, |
29 |
| - end: BlockNumber, |
| 29 | + range: RangeInclusive<BlockNumber>, |
30 | 30 | ) -> StdResult<Vec<CardanoTransaction>>;
|
31 | 31 |
|
32 | 32 | /// Get stored transactions up to the given beacon
|
@@ -144,7 +144,7 @@ impl CardanoTransactionsImporter {
|
144 | 144 |
|
145 | 145 | let transactions: Vec<CardanoTransaction> = self
|
146 | 146 | .transaction_store
|
147 |
| - .get_transactions_between(start, end) |
| 147 | + .get_transactions_between(start..=end) |
148 | 148 | .await?;
|
149 | 149 |
|
150 | 150 | let block_ranges_with_merkle_root: Vec<(BlockRange, MKTreeNode)> = block_ranges
|
@@ -315,8 +315,8 @@ mod tests {
|
315 | 315 | .returning(|| Ok(Some((0, BlockRange::LENGTH * 5 + 1))));
|
316 | 316 | store_mock
|
317 | 317 | .expect_get_transactions_between()
|
318 |
| - .withf(|start, end| start == &0 && end == &(BlockRange::LENGTH * 5)) |
319 |
| - .return_once(move |_, _| Ok(expected_stored_transactions)) |
| 318 | + .withf(|range| range == &(0..=(BlockRange::LENGTH * 5))) |
| 319 | + .return_once(move |_| Ok(expected_stored_transactions)) |
320 | 320 | .once();
|
321 | 321 | store_mock
|
322 | 322 | .expect_store_block_ranges()
|
@@ -441,10 +441,8 @@ mod tests {
|
441 | 441 | .returning(|| Ok(Some((BlockRange::LENGTH + 2, BlockRange::LENGTH * 5 + 1))));
|
442 | 442 | store_mock
|
443 | 443 | .expect_get_transactions_between()
|
444 |
| - .withf(|start, end| { |
445 |
| - start == &BlockRange::LENGTH && end == &(BlockRange::LENGTH * 5) |
446 |
| - }) |
447 |
| - .return_once(move |_, _| Ok(expected_stored_transactions)) |
| 444 | + .withf(|range| range == &(BlockRange::LENGTH..=(BlockRange::LENGTH * 5))) |
| 445 | + .return_once(move |_| Ok(expected_stored_transactions)) |
448 | 446 | .once();
|
449 | 447 | store_mock
|
450 | 448 | .expect_store_block_ranges()
|
@@ -502,7 +500,7 @@ mod tests {
|
502 | 500 | .returning(|| Ok(Some((0, BlockRange::LENGTH * 2))));
|
503 | 501 | store_mock
|
504 | 502 | .expect_get_transactions_between()
|
505 |
| - .return_once(move |_, _| Ok(expected_stored_transactions)) |
| 503 | + .return_once(move |_| Ok(expected_stored_transactions)) |
506 | 504 | .once();
|
507 | 505 | store_mock
|
508 | 506 | .expect_store_block_ranges()
|
|
0 commit comments