delete all pending txs & processed msgs before stopping batch submitt…

…er (#75)
initia-labs · Feb 6, 2025 · 4e3e5e4 · 4e3e5e4
1 parent cb1812c
commit 4e3e5e4
Showing 1 changed file with 9 additions and 0 deletions.
diff --git a/executor/batchsubmitter/batch.go b/executor/batchsubmitter/batch.go
@@ -56,6 +56,15 @@ func (bs *BatchSubmitter) prepareBatch(blockHeight int64) error {
 			return errors.Wrap(err, "failed to set synced height")
 		}
 
+		err = node.DeleteProcessedMsgs(bs.da.DB())
+		if err != nil {
+			return errors.Wrap(err, "failed to delete processed msgs")
+		}
+		err = node.DeletePendingTxs(bs.da.DB())
+		if err != nil {
+			return errors.Wrap(err, "failed to delete pending txs")
+		}
+
 		// error will restart block process from nextBatchInfo.Output.L2BlockNumber + 1
 		panic(fmt.Errorf("batch info updated: reset from %d", nextBatchInfo.Output.L2BlockNumber))
 	}