diff --git a/cmd/env.go b/cmd/env.go index 4fe244c..766378b 100644 --- a/cmd/env.go +++ b/cmd/env.go @@ -49,16 +49,14 @@ const ( PROM_HTTP_PORT = "PROM_HTTP_PORT" PROM_DB_STATS = "PROM_DB_STATS" - PRERUN_ONLY = "PRERUN_ONLY" - PRERUN_PARALLEL = "PRERUN_PARALLEL" - PRERUN_RANGE_START = "PRERUN_RANGE_START" - PRERUN_RANGE_STOP = "PRERUN_RANGE_STOP" - PRERUN_INTERMEDIATE_STATE_NODES = "PRERUN_INTERMEDIATE_STATE_NODES" - PRERUN_INTERMEDIATE_STORAGE_NODES = "PRERUN_INTERMEDIATE_STORAGE_NODES" - PRERUN_INCLUDE_BLOCK = "PRERUN_INCLUDE_BLOCK" - PRERUN_INCLUDE_RECEIPTS = "PRERUN_INCLUDE_RECEIPTS" - PRERUN_INCLUDE_TD = "PRERUN_INCLUDE_TD" - PRERUN_INCLUDE_CODE = "PRERUN_INCLUDE_CODE" + PRERUN_ONLY = "PRERUN_ONLY" + PRERUN_PARALLEL = "PRERUN_PARALLEL" + PRERUN_RANGE_START = "PRERUN_RANGE_START" + PRERUN_RANGE_STOP = "PRERUN_RANGE_STOP" + PRERUN_INCLUDE_BLOCK = "PRERUN_INCLUDE_BLOCK" + PRERUN_INCLUDE_RECEIPTS = "PRERUN_INCLUDE_RECEIPTS" + PRERUN_INCLUDE_TD = "PRERUN_INCLUDE_TD" + PRERUN_INCLUDE_CODE = "PRERUN_INCLUDE_CODE" LOG_LEVEL = "LOG_LEVEL" LOG_FILE_PATH = "LOG_FILE_PATH" @@ -141,8 +139,6 @@ func init() { viper.BindEnv("prerun.parallel", PRERUN_PARALLEL) viper.BindEnv("prerun.start", PRERUN_RANGE_START) viper.BindEnv("prerun.stop", PRERUN_RANGE_STOP) - viper.BindEnv("prerun.params.intermediateStateNodes", PRERUN_INTERMEDIATE_STATE_NODES) - viper.BindEnv("prerun.params.intermediateStorageNodes", PRERUN_INTERMEDIATE_STORAGE_NODES) viper.BindEnv("prerun.params.includeBlock", PRERUN_INCLUDE_BLOCK) viper.BindEnv("prerun.params.includeReceipts", PRERUN_INCLUDE_RECEIPTS) viper.BindEnv("prerun.params.includeTD", PRERUN_INCLUDE_TD) diff --git a/cmd/root.go b/cmd/root.go index ae60671..e957938 100644 --- a/cmd/root.go +++ b/cmd/root.go @@ -163,8 +163,6 @@ func init() { rootCmd.PersistentFlags().Bool("prerun-only", false, "only process pre-configured ranges; exit afterwards") rootCmd.PersistentFlags().Int("prerun-start", 0, "start height for a prerun range") rootCmd.PersistentFlags().Int("prerun-stop", 0, "stop height for a prerun range") - rootCmd.PersistentFlags().Bool("prerun-intermediate-state-nodes", true, "include intermediate state nodes in state diff") - rootCmd.PersistentFlags().Bool("prerun-intermediate-storage-nodes", true, "include intermediate storage nodes in state diff") rootCmd.PersistentFlags().Bool("prerun-include-block", true, "include block data in the statediff payload") rootCmd.PersistentFlags().Bool("prerun-include-receipts", true, "include receipts in the statediff payload") rootCmd.PersistentFlags().Bool("prerun-include-td", true, "include td in the statediff payload") @@ -224,8 +222,6 @@ func init() { viper.BindPFlag("prerun.parallel", rootCmd.PersistentFlags().Lookup("prerun-parallel")) viper.BindPFlag("prerun.start", rootCmd.PersistentFlags().Lookup("prerun-start")) viper.BindPFlag("prerun.stop", rootCmd.PersistentFlags().Lookup("prerun-stop")) - viper.BindPFlag("prerun.params.intermediateStateNodes", rootCmd.PersistentFlags().Lookup("prerun-intermediate-state-nodes")) - viper.BindPFlag("prerun.params.intermediateStorageNodes", rootCmd.PersistentFlags().Lookup("prerun-intermediate-storage-nodes")) viper.BindPFlag("prerun.params.includeBlock", rootCmd.PersistentFlags().Lookup("prerun-include-block")) viper.BindPFlag("prerun.params.includeReceipts", rootCmd.PersistentFlags().Lookup("prerun-include-receipts")) viper.BindPFlag("prerun.params.includeTD", rootCmd.PersistentFlags().Lookup("prerun-include-td")) diff --git a/cmd/serve.go b/cmd/serve.go index 6ba7b7d..6f725e2 100644 --- a/cmd/serve.go +++ b/cmd/serve.go @@ -22,6 +22,7 @@ import ( "os/signal" "runtime" "sync" + "syscall" "github.com/ethereum/go-ethereum/rpc" "github.com/sirupsen/logrus" @@ -113,7 +114,7 @@ func serve() { // clean shutdown shutdown := make(chan os.Signal) - signal.Notify(shutdown, os.Interrupt) + signal.Notify(shutdown, syscall.SIGINT) <-shutdown logWithCommand.Info("Received interrupt signal, shutting down") statediffService.Stop() diff --git a/cmd/util.go b/cmd/util.go index a906a64..9586f3b 100644 --- a/cmd/util.go +++ b/cmd/util.go @@ -50,12 +50,10 @@ func setupPreRunRanges() []sd.RangeRequest { return nil } preRunParams := statediff.Params{ - IntermediateStateNodes: viper.GetBool("prerun.params.intermediateStateNodes"), - IntermediateStorageNodes: viper.GetBool("prerun.params.intermediateStorageNodes"), - IncludeBlock: viper.GetBool("prerun.params.includeBlock"), - IncludeReceipts: viper.GetBool("prerun.params.includeReceipts"), - IncludeTD: viper.GetBool("prerun.params.includeTD"), - IncludeCode: viper.GetBool("prerun.params.includeCode"), + IncludeBlock: viper.GetBool("prerun.params.includeBlock"), + IncludeReceipts: viper.GetBool("prerun.params.includeReceipts"), + IncludeTD: viper.GetBool("prerun.params.includeTD"), + IncludeCode: viper.GetBool("prerun.params.includeCode"), } var addrStrs []string viper.UnmarshalKey("prerun.params.watchedAddresses", &addrStrs)