Example migration

crates/sequencer/src/db_migrations/mod.rs

@@ -1 +1,11 @@
+use std::sync::OnceLock;
 
+use sov_db::ledger_db::migrations::LedgerMigration;
+
+mod pruned_height;
+
+pub(crate) fn migrations() -> &'static Vec<Box<dyn LedgerMigration + Send + Sync + 'static>> {
+    static MIGRATIONS: OnceLock<Vec<Box<dyn LedgerMigration + Send + Sync + 'static>>> =
+        OnceLock::new();
+    MIGRATIONS.get_or_init(|| vec![Box::new(pruned_height::MigratePrunedL2Height {})])
+}

crates/sequencer/src/db_migrations/pruned_height.rs

@@ -0,0 +1,25 @@
+use std::sync::Arc;
+
+use sov_db::ledger_db::migrations::{LedgerMigration, MigrationName, MigrationVersion};
+use sov_db::ledger_db::{LedgerDB, SharedLedgerOps};
+
+pub(super) struct MigratePrunedL2Height {}
+
+impl LedgerMigration for MigratePrunedL2Height {
+    fn identifier(&self) -> (MigrationName, MigrationVersion) {
+        ("MigratePrunedL2Height".to_owned(), 1)
+    }
+
+    fn execute(&self, ledger_db: Arc<LedgerDB>) -> anyhow::Result<()> {
+        let Some(mut last_pruned_height) = ledger_db.get_last_pruned_l2_height()? else {
+            // No need to do any migration
+            return Ok(());
+        };
+
+        // Example
+        last_pruned_height += 10;
+        ledger_db.set_last_pruned_l2_height(last_pruned_height)?;
+
+        Ok(())
+    }
+}

crates/sequencer/src/sequencer.rs

@@ -30,6 +30,7 @@ use reth_transaction_pool::{
 };
 use sov_accounts::Accounts;
 use sov_accounts::Response::{AccountEmpty, AccountExists};
+use sov_db::ledger_db::migrations::LedgerDBMigrator;
 use sov_db::ledger_db::SequencerLedgerOps;
 use sov_db::schema::types::{BatchNumber, SlotNumber};
 use sov_modules_api::hooks::HookSoftConfirmationInfo;
@@ -817,6 +818,13 @@ where
 
     #[instrument(level = "trace", skip(self), err, ret)]
     pub async fn run(&mut self) -> Result<(), anyhow::Error> {
+        let migrator = LedgerDBMigrator::new(
+            self.ledger_db.path().to_path_buf(),
+            crate::db_migrations::migrations(),
+        );
+
+        migrator.migrate(Some(100))?;
+
         if self.batch_hash != [0; 32] {
             // Resubmit if there were pending commitments on restart, skip it on first init
             self.resubmit_pending_commitments().await?;