github/reth
1
1
Fork 0
mirror of https://github.com/paradigmxyz/reth.git synced 2026-01-26 23:58:46 -05:00
Code Issues Packages Projects Releases Wiki Activity

test(rpc): filter test is taking too long (#11288)

Browse Source
This commit is contained in:
Alexey Shekhirin
2024-09-27 19:38:28 +01:00
committed by GitHub
parent d8f16b83b7
commit 1bbf8b6306
1 changed files with 17 additions and 17 deletions
Download Patch File Download Diff File Expand all files Collapse all files

34
crates/rpc/rpc/src/eth/filter.rs
View File

@@ -698,28 +698,28 @@ impl Iterator for BlockRangeInclusiveIter {
#[cfg(test)]
mod tests {
use super::*;
use rand::{thread_rng, Rng};
use rand::Rng;
use reth_testing_utils::generators;
#[test]
fn test_block_range_iter() {
for _ in 0..100 {
let mut rng = thread_rng();
let start = rng.gen::<u32>() as u64;
let end = start.saturating_add(rng.gen::<u32>() as u64);
let step = rng.gen::<u16>() as u64;
let range = start..=end;
let mut iter = BlockRangeInclusiveIter::new(range.clone(), step);
let (from, mut end) = iter.next().unwrap();
assert_eq!(from, start);
assert_eq!(end, (from + step).min(*range.end()));
let mut rng = generators::rng();
for (next_from, next_end) in iter {
// ensure range starts with previous end + 1
assert_eq!(next_from, end + 1);
end = next_end;
}
let start = rng.gen::<u32>() as u64;
let end = start.saturating_add(rng.gen::<u32>() as u64);
let step = rng.gen::<u16>() as u64;
let range = start..=end;
let mut iter = BlockRangeInclusiveIter::new(range.clone(), step);
let (from, mut end) = iter.next().unwrap();
assert_eq!(from, start);
assert_eq!(end, (from + step).min(*range.end()));
assert_eq!(end, *range.end());
for (next_from, next_end) in iter {
// ensure range starts with previous end + 1
assert_eq!(next_from, end + 1);
end = next_end;
}
assert_eq!(end, *range.end());
}
}