From e16b311880c5c946e3b1c11febefcff7a94c1ddb Mon Sep 17 00:00:00 2001
From: patrick <patrickkuo@me.com>
Date: Mon, 6 Jan 2025 11:55:26 +0000
Subject: [PATCH] add genesis checkpoint to indexer args, this will be used as
 the default checkpoint.

---
 crates/sui-indexer-alt-framework/src/lib.rs | 13 ++++++++++++-
 1 file changed, 12 insertions(+), 1 deletion(-)

diff --git a/crates/sui-indexer-alt-framework/src/lib.rs b/crates/sui-indexer-alt-framework/src/lib.rs
index ac4d9902682956..334ba899953631 100644
--- a/crates/sui-indexer-alt-framework/src/lib.rs
+++ b/crates/sui-indexer-alt-framework/src/lib.rs
@@ -60,6 +60,11 @@ pub struct IndexerArgs {
     /// Address to serve Prometheus Metrics from.
     #[arg(long, default_value_t = Self::default().metrics_address)]
     pub metrics_address: SocketAddr,
+
+    /// The genesis checkpoint to start ingestion from, this is useful for app indexer which only
+    /// needs to index checkpoint after the app contract's genesis.
+    #[arg(long, default_value_t = 0)]
+    pub genesis_checkpoint: u64,
 }
 
 pub struct Indexer {
@@ -103,6 +108,9 @@ pub struct Indexer {
 
     /// The handles for every task spawned by this indexer, used to manage graceful shutdown.
     handles: Vec<JoinHandle<()>>,
+
+    /// Default checkpoint lowerbound.
+    genesis_checkpoint: u64,
 }
 
 impl Indexer {
@@ -135,6 +143,7 @@ impl Indexer {
             pipeline,
             skip_watermark,
             metrics_address,
+            genesis_checkpoint,
         } = indexer_args;
 
         let db = Db::for_write(db_args)
@@ -173,6 +182,7 @@ impl Indexer {
             cancel,
             first_checkpoint_from_watermark: u64::MAX,
             handles: vec![],
+            genesis_checkpoint,
         })
     }
 
@@ -427,7 +437,7 @@ impl Indexer {
             watermark
                 .as_ref()
                 .map(|w| w.checkpoint_hi_inclusive as u64 + 1)
-                .unwrap_or_default()
+                .unwrap_or(self.genesis_checkpoint)
         };
 
         self.first_checkpoint_from_watermark =
@@ -445,6 +455,7 @@ impl Default for IndexerArgs {
             pipeline: vec![],
             skip_watermark: false,
             metrics_address: "0.0.0.0:9184".parse().unwrap(),
+            genesis_checkpoint: 0,
         }
     }
 }