worker: checkpoint on some fixed interval

crates/consensus-logic/src/worker.rs

@@ -216,10 +216,11 @@ fn handle_sync_event<D: Database, E: ExecEngineCtl>(
     // Make sure that the new state index is set as expected.
     assert_eq!(state.state_tracker.cur_state_idx(), ev_idx);
 
-    // Write the state checkpoint.
-    // TODO Don't do this on every update.
-    let css = state.database.client_state_store();
-    css.write_client_state_checkpoint(ev_idx, new_state.as_ref().clone())?;
+    // Write the state checkpoint on interval.
+    if ev_idx % state.params.run.client_checkpoint_interval as u64 == 0 {
+        let css = state.database.client_state_store();
+        css.write_client_state_checkpoint(ev_idx, new_state.as_ref().clone())?;
+    }
 
     // Broadcast the update to all the different things listening (which should
     // be consolidated).

crates/primitives/src/params.rs

@@ -34,6 +34,8 @@ pub struct RollupParams {
 pub struct RunParams {
     /// Number of blocks that we follow the L1 from.
     pub l1_follow_distance: u64,
+    /// Number of events after which we checkpoint the client
+    pub client_checkpoint_interval: u32,
 }
 
 /// Combined set of parameters across all the consensus logic.

crates/test-utils/src/l2.rs

@@ -83,6 +83,7 @@ pub fn gen_params() -> Params {
         },
         run: RunParams {
             l1_follow_distance: 3,
+            client_checkpoint_interval: 10,
         },
     }
 }

sequencer/src/config.rs

@@ -17,6 +17,7 @@ pub struct SyncParams {
     pub l1_follow_distance: u64,
     pub max_reorg_depth: u32,
     pub client_poll_dur_ms: u32,
+    pub client_checkpoint_interval: u32,
 }
 
 #[derive(Deserialize, Debug)]
@@ -47,7 +48,7 @@ pub struct Config {
 }
 
 impl Config {
-    pub fn new() -> Config {
+    pub fn default() -> Config {
         Self {
             bitcoind_rpc: BitcoindParams {
                 rpc_url: String::new(),
@@ -64,6 +65,7 @@ impl Config {
                 l1_follow_distance: 6,
                 max_reorg_depth: 4,
                 client_poll_dur_ms: 200,
+                client_checkpoint_interval: 10,
             },
             exec: ExecParams {
                 reth: RethELParams {
@@ -123,6 +125,7 @@ mod test {
             l1_follow_distance = 6
             max_reorg_depth = 4
             client_poll_dur_ms = 200
+            client_checkpoint_interval = 10
 
             [exec.reth]
             rpc_url = "http://localhost:8551"

sequencer/src/main.rs

@@ -81,7 +81,7 @@ fn main_inner(args: Args) -> anyhow::Result<()> {
     // initialize the full configuration
     let mut config = match args.config.as_ref() {
         Some(config_path) => load_configuration(config_path)?,
-        None => Config::new(),
+        None => Config::default(),
     };
 
     // Values passed over arguments get the precedence over the configuration files
@@ -111,6 +111,7 @@ fn main_inner(args: Args) -> anyhow::Result<()> {
         },
         run: RunParams {
             l1_follow_distance: config.sync.l1_follow_distance,
+            client_checkpoint_interval: config.sync.client_checkpoint_interval,
         },
     };