diff --git a/sequencer_core/src/sequecer_store/block_store.rs b/sequencer_core/src/sequecer_store/block_store.rs index 5f668d4..e4e3493 100644 --- a/sequencer_core/src/sequecer_store/block_store.rs +++ b/sequencer_core/src/sequecer_store/block_store.rs @@ -31,6 +31,6 @@ impl SequecerBlockStore { } pub fn put_block_at_id(&self, block: Block) -> Result<()> { - Ok(self.dbio.put_block(block)?) + Ok(self.dbio.put_block(block, false)?) } } diff --git a/storage/src/lib.rs b/storage/src/lib.rs index 2e87492..5a341a9 100644 --- a/storage/src/lib.rs +++ b/storage/src/lib.rs @@ -149,7 +149,7 @@ impl RocksDBIO { ) .map_err(|rerr| DbError::rocksdb_cast_message(rerr, None))?; - self.put_block(block)?; + self.put_block(block, true)?; Ok(()) } @@ -173,13 +173,15 @@ impl RocksDBIO { Ok(()) } - pub fn put_block(&self, block: Block) -> DbResult<()> { + pub fn put_block(&self, block: Block, first: bool) -> DbResult<()> { let cf_block = self.block_column(); + if !first { let last_curr_block = self.get_meta_last_block_in_db()?; if block.block_id > last_curr_block { self.put_meta_last_block_in_db(block.block_id)?; + } } self.db