diff --git a/crates/storage/provider/src/providers/database/provider.rs b/crates/storage/provider/src/providers/database/provider.rs index fc2555254ab9..74be815111e7 100644 --- a/crates/storage/provider/src/providers/database/provider.rs +++ b/crates/storage/provider/src/providers/database/provider.rs @@ -1644,29 +1644,20 @@ impl TransactionsProvider for DatabaseProvider { &self, range: impl RangeBounds, ) -> ProviderResult>> { - let range = to_range(range); - self.cursor_collect_with_capacity( - &mut self.tx.cursor_read::>()?, - RawKey::new(range.start)..RawKey::new(range.end), - range_size_hint(&range).unwrap_or(0), - |_, v| Ok(v), + self.get_range_with_snapshot( + SnapshotSegment::Transactions, + to_range(range), + |snapshot, range, _| snapshot.raw_transactions_by_tx_range(range), + |range, _| { + self.cursor_collect_with_capacity( + &mut self.tx.cursor_read::>()?, + RawKey::new(range.start)..RawKey::new(range.end), + range_size_hint(&range).unwrap_or(0), + |_, v| Ok(v), + ) + }, + |_| true, ) - - // TODO(alexey): uncomment to query from snapshots - // self.get_range_with_snapshot( - // SnapshotSegment::Transactions, - // to_range(range), - // |snapshot, range, _| snapshot.raw_transactions_by_tx_range(range), - // |range, _| { - // self.cursor_collect_with_capacity( - // &mut self.tx.cursor_read::>()?, - // RawKey::new(range.start)..RawKey::new(range.end), - // range_size_hint(&range).unwrap_or(0), - // |_, v| Ok(v), - // ) - // }, - // |_| true, - // ) } fn senders_by_tx_range(