fix(claimer): make genesis block configurable

cartesi · Nov 21, 2023 · e17f391 · e17f391
1 parent 0169aed
commit e17f391
Show file tree

Hide file tree

Showing 4 changed files with 9 additions and 2 deletions.
diff --git a/offchain/authority-claimer/src/checker.rs b/offchain/authority-claimer/src/checker.rs
@@ -18,7 +18,6 @@ use std::sync::Arc;
 use tracing::trace;
 use url::{ParseError, Url};
 
-const GENESIS_BLOCK: u64 = 1;
 const MAX_RETRIES: u32 = 10;
 const INITIAL_BACKOFF: u64 = 1000;
 
@@ -75,6 +74,7 @@ impl DefaultDuplicateChecker {
         http_endpoint: String,
         history_address: Address,
         confirmations: usize,
+        genesis_block: u64,
     ) -> Result<Self, DuplicateCheckerError> {
         let http = Http::new(Url::parse(&http_endpoint).context(ParseSnafu)?);
         let retry_client = RetryClient::new(
@@ -93,7 +93,7 @@ impl DefaultDuplicateChecker {
             history,
             claims: Vec::new(),
             confirmations,
-            next_block_to_read: GENESIS_BLOCK,
+            next_block_to_read: genesis_block,
         })
     }
 }

diff --git a/offchain/authority-claimer/src/config/cli.rs b/offchain/authority-claimer/src/config/cli.rs
@@ -44,6 +44,10 @@ pub(crate) struct AuthorityClaimerCLI {
 
     #[command(flatten)]
     pub blockchain_config: BlockchainCLIConfig,
+
+    /// Genesis block for reading blockchain events
+    #[arg(long, env, default_value_t = 1)]
+    pub genesis_block: u64,
 }
 
 impl TryFrom<AuthorityClaimerCLI> for AuthorityClaimerConfig {
@@ -73,6 +77,7 @@ impl TryFrom<AuthorityClaimerCLI> for AuthorityClaimerConfig {
             broker_config,
             log_config,
             blockchain_config,
+            genesis_block: cli_config.genesis_block,
         })
     }
 }

diff --git a/offchain/authority-claimer/src/config/mod.rs b/offchain/authority-claimer/src/config/mod.rs
@@ -28,6 +28,7 @@ pub struct AuthorityClaimerConfig {
     pub broker_config: BrokerConfig,
     pub log_config: LogConfig,
     pub blockchain_config: BlockchainConfig,
+    pub genesis_block: u64,
 }
 
 #[derive(Debug, Clone)]

diff --git a/offchain/authority-claimer/src/lib.rs b/offchain/authority-claimer/src/lib.rs
@@ -48,6 +48,7 @@ pub async fn run(config: Config) -> Result<(), Box<dyn Error>> {
         config.tx_manager_config.provider_http_endpoint.clone(),
         config.blockchain_config.history_address.clone(),
         config.tx_manager_config.default_confirmations,
+        config.genesis_block,
     )?;
 
     // Creating the transaction sender.