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

fix: Prevent potentially unreliable reads

Browse Source
This commit is contained in:
sprites0
2025-07-04 14:52:14 -04:00
parent bc49c22094
commit 9dba0d4b64
2 changed files with 9 additions and 19 deletions
Download Patch File Download Diff File Expand all files Collapse all files

15
bin/reth/src/block_ingest.rs
View File

@ -149,16 +149,11 @@ impl BlockIngest {
let f = ((height - 1) / 1_000_000) * 1_000_000;
let s = ((height - 1) / 1_000) * 1_000;
let path = format!("{}/{f}/{s}/{height}.rmp.lz4", self.ingest_dir.to_string_lossy());
if std::path::Path::new(&path).exists() {
let file = std::fs::File::open(path).unwrap();
let file = std::io::BufReader::new(file);
let mut decoder = lz4_flex::frame::FrameDecoder::new(file);
let blocks: Vec<BlockAndReceipts> = rmp_serde::from_read(&mut decoder).unwrap();
info!("Returning s3 synced block for @ Height [{height}]");
Some(blocks[0].clone())
} else {
None
}
let file = std::fs::read(path).ok()?;
let mut decoder = lz4_flex::frame::FrameDecoder::new(&file[..]);
let blocks: Vec<BlockAndReceipts> = rmp_serde::from_read(&mut decoder).unwrap();
info!("Returning s3 synced block for @ Height [{height}]");
Some(blocks[0].clone())
}
async fn try_collect_local_block(&self, height: u64) -> Option<BlockAndReceipts> {