separate config for committer from block

README.md

@@ -331,6 +331,17 @@ committer:
   blocksPerCommit: 1000
 ```
 
+#### Committer From Block
+From which block to start committing. Default is `0`.
+
+cmd: `--committer-from-block`
+env: `COMMITTER_FROMBLOCK`
+yaml:
+```yaml
+committer:
+  fromBlock: 20000000
+```
+
 #### Reorg Handler
 Whether to enable the reorg handler. Default is `true`.
 

cmd/root.go

@@ -58,6 +58,7 @@ func init() {
 	rootCmd.PersistentFlags().Bool("committer-enabled", true, "Toggle committer")
 	rootCmd.PersistentFlags().Int("committer-blocks-per-commit", 10, "How many blocks to commit each interval")
 	rootCmd.PersistentFlags().Int("committer-interval", 1000, "How often to commit blocks in milliseconds")
+	rootCmd.PersistentFlags().Int("committer-from-block", 0, "From which block to start committing")
 	rootCmd.PersistentFlags().Bool("reorgHandler-enabled", true, "Toggle reorg handler")
 	rootCmd.PersistentFlags().Int("reorgHandler-interval", 1000, "How often to run reorg handler in milliseconds")
 	rootCmd.PersistentFlags().Int("reorgHandler-blocks-per-scan", 100, "How many blocks to scan for reorgs")
@@ -109,6 +110,7 @@ func init() {
 	viper.BindPFlag("committer.enabled", rootCmd.PersistentFlags().Lookup("committer-enabled"))
 	viper.BindPFlag("committer.blocksPerCommit", rootCmd.PersistentFlags().Lookup("committer-blocks-per-commit"))
 	viper.BindPFlag("committer.interval", rootCmd.PersistentFlags().Lookup("committer-interval"))
+	viper.BindPFlag("committer.fromBlock", rootCmd.PersistentFlags().Lookup("committer-from-block"))
 	viper.BindPFlag("reorgHandler.enabled", rootCmd.PersistentFlags().Lookup("reorgHandler-enabled"))
 	viper.BindPFlag("reorgHandler.interval", rootCmd.PersistentFlags().Lookup("reorgHandler-interval"))
 	viper.BindPFlag("reorgHandler.blocksPerScan", rootCmd.PersistentFlags().Lookup("reorgHandler-blocks-per-scan"))

configs/config.go

@@ -26,6 +26,7 @@ type CommitterConfig struct {
 	Enabled         bool `mapstructure:"enabled"`
 	Interval        int  `mapstructure:"interval"`
 	BlocksPerCommit int  `mapstructure:"blocksPerCommit"`
+	FromBlock       int  `mapstructure:"fromBlock"`
 }
 
 type ReorgHandlerConfig struct {

internal/orchestrator/committer.go

@@ -39,7 +39,7 @@ func NewCommitter(rpc rpc.IRPCClient, storage storage.IStorage) *Committer {
 		triggerIntervalMs: triggerInterval,
 		blocksPerCommit:   blocksPerCommit,
 		storage:           storage,
-		pollFromBlock:     big.NewInt(int64(config.Cfg.Poller.FromBlock)),
+		pollFromBlock:     big.NewInt(int64(config.Cfg.Committer.FromBlock)),
 		rpc:               rpc,
 	}
 }