mirror of
https://github.com/0glabs/0g-chain.git
synced 2024-12-26 00:05:18 +00:00
Check Pruning Config (#560)
* add pruning config check * patch cmd to update config
This commit is contained in:
parent
0328181c7d
commit
869189054d
@ -2,6 +2,7 @@ package main
|
|||||||
|
|
||||||
import (
|
import (
|
||||||
"encoding/json"
|
"encoding/json"
|
||||||
|
"fmt"
|
||||||
"io"
|
"io"
|
||||||
|
|
||||||
"github.com/spf13/cobra"
|
"github.com/spf13/cobra"
|
||||||
@ -16,7 +17,9 @@ import (
|
|||||||
|
|
||||||
"github.com/cosmos/cosmos-sdk/baseapp"
|
"github.com/cosmos/cosmos-sdk/baseapp"
|
||||||
"github.com/cosmos/cosmos-sdk/client/flags"
|
"github.com/cosmos/cosmos-sdk/client/flags"
|
||||||
|
"github.com/cosmos/cosmos-sdk/codec"
|
||||||
"github.com/cosmos/cosmos-sdk/server"
|
"github.com/cosmos/cosmos-sdk/server"
|
||||||
|
srvconfig "github.com/cosmos/cosmos-sdk/server/config"
|
||||||
"github.com/cosmos/cosmos-sdk/store"
|
"github.com/cosmos/cosmos-sdk/store"
|
||||||
sdk "github.com/cosmos/cosmos-sdk/types"
|
sdk "github.com/cosmos/cosmos-sdk/types"
|
||||||
"github.com/cosmos/cosmos-sdk/x/auth"
|
"github.com/cosmos/cosmos-sdk/x/auth"
|
||||||
@ -46,14 +49,14 @@ func main() {
|
|||||||
rootCmd := &cobra.Command{
|
rootCmd := &cobra.Command{
|
||||||
Use: "kvd",
|
Use: "kvd",
|
||||||
Short: "Kava Daemon (server)",
|
Short: "Kava Daemon (server)",
|
||||||
PersistentPreRunE: server.PersistentPreRunEFn(ctx),
|
PersistentPreRunE: persistentPreRunEFn(ctx),
|
||||||
}
|
}
|
||||||
|
|
||||||
rootCmd.AddCommand(
|
rootCmd.AddCommand(
|
||||||
genutilcli.InitCmd(ctx, cdc, app.ModuleBasics, app.DefaultNodeHome),
|
genutilcli.InitCmd(ctx, cdc, app.ModuleBasics, app.DefaultNodeHome),
|
||||||
genutilcli.CollectGenTxsCmd(ctx, cdc, auth.GenesisAccountIterator{}, app.DefaultNodeHome),
|
genutilcli.CollectGenTxsCmd(ctx, cdc, auth.GenesisAccountIterator{}, app.DefaultNodeHome),
|
||||||
migrate.MigrateGenesisCmd(ctx, cdc),
|
migrate.MigrateGenesisCmd(ctx, cdc),
|
||||||
kava3.WriteGenesisParamsCmd(cdc),
|
writeParamsAndConfigCmd(cdc),
|
||||||
genutilcli.GenTxCmd(
|
genutilcli.GenTxCmd(
|
||||||
ctx,
|
ctx,
|
||||||
cdc,
|
cdc,
|
||||||
@ -116,3 +119,57 @@ func exportAppStateAndTMValidators(
|
|||||||
tempApp := app.NewApp(logger, db, traceStore, true, map[int64]bool{}, uint(1))
|
tempApp := app.NewApp(logger, db, traceStore, true, map[int64]bool{}, uint(1))
|
||||||
return tempApp.ExportAppStateAndValidators(forZeroHeight, jailWhiteList)
|
return tempApp.ExportAppStateAndValidators(forZeroHeight, jailWhiteList)
|
||||||
}
|
}
|
||||||
|
|
||||||
|
// persistentPreRunEFn wraps the sdk function server.PersistentPreRunEFn to error on invaid pruning config.
|
||||||
|
func persistentPreRunEFn(ctx *server.Context) func(*cobra.Command, []string) error {
|
||||||
|
|
||||||
|
originalFunc := server.PersistentPreRunEFn(ctx)
|
||||||
|
|
||||||
|
return func(cmd *cobra.Command, args []string) error {
|
||||||
|
|
||||||
|
if err := originalFunc(cmd, args); err != nil {
|
||||||
|
return err
|
||||||
|
}
|
||||||
|
|
||||||
|
// check pruning config for `kvd start`
|
||||||
|
if cmd.Name() == "start" {
|
||||||
|
if viper.GetString("pruning") == store.PruningStrategySyncable {
|
||||||
|
return fmt.Errorf(
|
||||||
|
"invalid app config: pruning == '%s'. Update config (%s) with pruning set to '%s' or '%s'.",
|
||||||
|
store.PruningStrategySyncable, viper.ConfigFileUsed(), store.PruningStrategyNothing, store.PruningStrategyEverything,
|
||||||
|
)
|
||||||
|
}
|
||||||
|
}
|
||||||
|
return nil
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
// writeParamsAndConfigCmd patches the write-params cmd to additionally update the app pruning config.
|
||||||
|
func writeParamsAndConfigCmd(cdc *codec.Codec) *cobra.Command {
|
||||||
|
cmd := kava3.WriteGenesisParamsCmd(cdc)
|
||||||
|
originalFunc := cmd.RunE
|
||||||
|
|
||||||
|
wrappedFunc := func(cmd *cobra.Command, args []string) error {
|
||||||
|
|
||||||
|
if err := originalFunc(cmd, args); err != nil {
|
||||||
|
return err
|
||||||
|
}
|
||||||
|
|
||||||
|
// fetch the app config from viper
|
||||||
|
cfg, err := srvconfig.ParseConfig()
|
||||||
|
if err != nil {
|
||||||
|
return nil // don't return errors since as failures aren't critical
|
||||||
|
}
|
||||||
|
// don't prune any state, ie store everything
|
||||||
|
cfg.Pruning = store.PruningStrategyNothing
|
||||||
|
// write updated config
|
||||||
|
if viper.ConfigFileUsed() == "" {
|
||||||
|
return nil
|
||||||
|
}
|
||||||
|
srvconfig.WriteConfigFile(viper.ConfigFileUsed(), cfg)
|
||||||
|
return nil
|
||||||
|
}
|
||||||
|
|
||||||
|
cmd.RunE = wrappedFunc
|
||||||
|
return cmd
|
||||||
|
}
|
||||||
|
Loading…
Reference in New Issue
Block a user