jleony/nanoreth
1
0
Fork 0
mirror of https://github.com/hl-archive-node/nanoreth.git synced 2025-12-06 10:59:55 +00:00
Code Issues Packages Projects Releases Wiki Activity

chore: clippy

Browse Source
This commit is contained in:
sprites0
2025-07-01 03:19:02 +00:00
parent 670088392f
commit 4b078a1b2d
1 changed files with 5 additions and 10 deletions
Download Patch File Download Diff File Expand all files Collapse all files

15
src/pseudo_peer/sources/hl_node.rs
View File

@ -57,7 +57,7 @@ fn scan_hour_file(path: &Path, last_line: &mut usize, start_height: u64) -> Scan
let mut new_blocks = Vec::<BlockAndReceipts>::new(); let mut new_blocks = Vec::<BlockAndReceipts>::new();
let mut last_height = start_height; let mut last_height = start_height;
let lines: Vec<String> = reader.lines().collect::<Result<_, _>>().unwrap(); let lines: Vec<String> = reader.lines().collect::<Result<_, _>>().unwrap();
let skip = if *last_line == 0 { 0 } else { (last_line.clone()) - 1 }; let skip = if *last_line == 0 { 0 } else { *last_line - 1 };
for (line_idx, line) in lines.iter().enumerate().skip(skip) { for (line_idx, line) in lines.iter().enumerate().skip(skip) {
// Safety check ensuring efficiency // Safety check ensuring efficiency
@ -69,7 +69,7 @@ fn scan_hour_file(path: &Path, last_line: &mut usize, start_height: u64) -> Scan
} }
let LocalBlockAndReceipts(_block_timestamp, parsed_block): LocalBlockAndReceipts = let LocalBlockAndReceipts(_block_timestamp, parsed_block): LocalBlockAndReceipts =
serde_json::from_str(&line).expect("Failed to parse local block and receipts"); serde_json::from_str(line).expect("Failed to parse local block and receipts");
let height = match &parsed_block.block { let height = match &parsed_block.block {
EvmBlock::Reth115(b) => { EvmBlock::Reth115(b) => {
@ -107,7 +107,7 @@ impl BlockSource for HlNodeBlockSource {
// Not a one liner (using .or) to include logs // Not a one liner (using .or) to include logs
if let Some(block) = self.try_collect_local_block(height).await { if let Some(block) = self.try_collect_local_block(height).await {
info!("Returning locally synced block for @ Height [{height}]"); info!("Returning locally synced block for @ Height [{height}]");
return Ok(block); Ok(block)
} else { } else {
self.fallback.collect_block(height).await self.fallback.collect_block(height).await
} }
@ -154,13 +154,8 @@ impl HlNodeBlockSource {
if !new_blocks.is_empty() { if !new_blocks.is_empty() {
let mut u_cache = cache.lock().await; let mut u_cache = cache.lock().await;
for blk in new_blocks { for blk in new_blocks {
let h = match &blk.block { let EvmBlock::Reth115(b) = &blk.block;
EvmBlock::Reth115(b) => { u_cache.insert(b.header.header.number, blk);
let block_number = b.header.header.number;
block_number
}
};
u_cache.insert(h, blk);
} }
next_height = next_expected_height; next_height = next_expected_height;
} }