Skip to content

Commit f5e7761

Browse files
committed
fix(db): properly increment target for above_ methods
1 parent 602199f commit f5e7761

File tree

1 file changed

+4
-4
lines changed

1 file changed

+4
-4
lines changed

crates/db/src/provider.rs

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -337,7 +337,7 @@ where
337337
let mut items = Vec::new();
338338
trace!(target: "signet_db_lifecycle", "taking zenith headers");
339339
let mut cursor_write = self.tx_ref().cursor_write::<ZenithHeaders>()?;
340-
let mut walker = cursor_write.walk_range(target..)?;
340+
let mut walker = cursor_write.walk_range(target + 1..)?;
341341
while let Some((k, DbZenithHeader(e))) = walker.next().transpose()? {
342342
walker.delete_current()?;
343343
items.push((k, e))
@@ -352,7 +352,7 @@ where
352352
target: BlockNumber,
353353
_remove_from: StorageLocation,
354354
) -> ProviderResult<()> {
355-
self.remove::<ZenithHeaders>(target..)?;
355+
self.remove::<ZenithHeaders>(target + 1..)?;
356356
Ok(())
357357
}
358358

@@ -375,7 +375,7 @@ where
375375
target: BlockNumber,
376376
remove_from: StorageLocation,
377377
) -> ProviderResult<Vec<(BlockNumber, DbSignetEvent)>> {
378-
let range = target..=(1 + self.last_block_number()?);
378+
let range = target + 1..=self.last_block_number()?;
379379
let items = self.get_signet_events(range)?;
380380
self.remove_signet_events_above(target, remove_from)?;
381381
Ok(items)
@@ -390,7 +390,7 @@ where
390390
target: BlockNumber,
391391
_remove_from: StorageLocation,
392392
) -> ProviderResult<()> {
393-
self.remove::<SignetEvents>(target..)?;
393+
self.remove::<SignetEvents>(target + 1..)?;
394394
Ok(())
395395
}
396396

0 commit comments

Comments
 (0)