-
Notifications
You must be signed in to change notification settings - Fork 14
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
- Loading branch information
Showing
10 changed files
with
1,023 additions
and
25 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,260 @@ | ||
| package cmd | ||
|
|
||
| import ( | ||
| "errors" | ||
| "io" | ||
| "os" | ||
|
|
||
| cmtcfg "github.com/cometbft/cometbft/config" | ||
| dbm "github.com/cosmos/cosmos-db" | ||
| "github.com/spf13/cobra" | ||
| "github.com/spf13/viper" | ||
|
|
||
| "cosmossdk.io/log" | ||
| confixcmd "cosmossdk.io/tools/confix/cmd" | ||
|
|
||
| "github.com/cosmos/cosmos-sdk/client" | ||
| "github.com/cosmos/cosmos-sdk/client/debug" | ||
| "github.com/cosmos/cosmos-sdk/client/flags" | ||
| "github.com/cosmos/cosmos-sdk/client/keys" | ||
| "github.com/cosmos/cosmos-sdk/client/pruning" | ||
| "github.com/cosmos/cosmos-sdk/client/rpc" | ||
| "github.com/cosmos/cosmos-sdk/client/snapshot" | ||
| "github.com/cosmos/cosmos-sdk/codec" | ||
| codectypes "github.com/cosmos/cosmos-sdk/codec/types" | ||
| "github.com/cosmos/cosmos-sdk/server" | ||
| serverconfig "github.com/cosmos/cosmos-sdk/server/config" | ||
| servertypes "github.com/cosmos/cosmos-sdk/server/types" | ||
| sdk "github.com/cosmos/cosmos-sdk/types" | ||
| "github.com/cosmos/cosmos-sdk/types/module" | ||
| authcmd "github.com/cosmos/cosmos-sdk/x/auth/client/cli" | ||
| banktypes "github.com/cosmos/cosmos-sdk/x/bank/types" | ||
| "github.com/cosmos/cosmos-sdk/x/crisis" | ||
| genutilcli "github.com/cosmos/cosmos-sdk/x/genutil/client/cli" | ||
|
|
||
| "github.com/Finschia/finschia/v3/app" | ||
| ) | ||
|
|
||
| // initCometBFTConfig helps to override default CometBFT Config values. | ||
| // return cmtcfg.DefaultConfig if no custom configuration is required for the application. | ||
| func initCometBFTConfig() *cmtcfg.Config { | ||
| cfg := cmtcfg.DefaultConfig() | ||
|
|
||
| // these values put a higher strain on node memory | ||
| // cfg.P2P.MaxNumInboundPeers = 100 | ||
| // cfg.P2P.MaxNumOutboundPeers = 40 | ||
|
|
||
| return cfg | ||
| } | ||
|
|
||
| // initAppConfig helps to override default appConfig template and configs. | ||
| // return "", nil if no custom configuration is required for the application. | ||
| func initAppConfig() (string, interface{}) { | ||
| // The following code snippet is just for reference. | ||
|
|
||
| // CustomConfig defines an arbitrary custom config to extend app.toml. | ||
| // If you don't need it, you can remove it. | ||
| // If you wish to add fields that correspond to flags that aren't in the SDK server config, | ||
| // this custom config can as well help. | ||
| type CustomConfig struct { | ||
| CustomField string `mapstructure:"custom-field"` | ||
| } | ||
|
|
||
| type CustomAppConfig struct { | ||
| serverconfig.Config `mapstructure:",squash"` | ||
|
|
||
| Custom CustomConfig `mapstructure:"custom"` | ||
| } | ||
|
|
||
| // Optionally allow the chain developer to overwrite the SDK's default | ||
| // server config. | ||
| srvCfg := serverconfig.DefaultConfig() | ||
| // The SDK's default minimum gas price is set to "" (empty value) inside | ||
| // app.toml. If left empty by validators, the node will halt on startup. | ||
| // However, the chain developer can set a default app.toml value for their | ||
| // validators here. | ||
| // | ||
| // In summary: | ||
| // - if you leave srvCfg.MinGasPrices = "", all validators MUST tweak their | ||
| // own app.toml config, | ||
| // - if you set srvCfg.MinGasPrices non-empty, validators CAN tweak their | ||
| // own app.toml to override, or use this default value. | ||
| // | ||
| // srvCfg.BaseConfig.IAVLDisableFastNode = true // disable fastnode by default | ||
|
|
||
| // Now we set the custom config default values. | ||
| customAppConfig := CustomAppConfig{ | ||
| Config: *srvCfg, | ||
| Custom: CustomConfig{ | ||
| CustomField: "anything", | ||
| }, | ||
| } | ||
|
|
||
| // The default SDK app template is defined in serverconfig.DefaultConfigTemplate. | ||
| // We append the custom config template to the default one. | ||
| // And we set the default config to the custom app template. | ||
| customAppTemplate := serverconfig.DefaultConfigTemplate + ` | ||
| [custom] | ||
| # That field will be parsed by server.InterceptConfigsPreRunHandler and held by viper. | ||
| # Do not forget to add quotes around the value if it is a string. | ||
| custom-field = "{{ .Custom.CustomField }}"` | ||
|
|
||
| return customAppTemplate, customAppConfig | ||
| } | ||
|
|
||
| func initRootCmd( | ||
| rootCmd *cobra.Command, | ||
| txConfig client.TxConfig, | ||
| _ codectypes.InterfaceRegistry, | ||
| _ codec.Codec, | ||
| basicManager module.BasicManager, | ||
| ) { | ||
| cfg := sdk.GetConfig() | ||
| cfg.Seal() | ||
|
|
||
| rootCmd.AddCommand( | ||
| genutilcli.InitCmd(basicManager, app.DefaultNodeHome), | ||
| NewTestnetCmd(basicManager, banktypes.GenesisBalancesIterator{}), | ||
| debug.Cmd(), | ||
| confixcmd.ConfigCommand(), | ||
| pruning.Cmd(newApp, app.DefaultNodeHome), | ||
| snapshot.Cmd(newApp), | ||
| ) | ||
|
|
||
| server.AddCommands(rootCmd, app.DefaultNodeHome, newApp, appExport, addModuleInitFlags) | ||
|
|
||
| // add keybase, auxiliary RPC, query, genesis, and tx child commands | ||
| rootCmd.AddCommand( | ||
| server.StatusCommand(), | ||
| genesisCommand(txConfig, basicManager), | ||
| queryCommand(), | ||
| txCommand(), | ||
| keys.Commands(), | ||
| ) | ||
| } | ||
|
|
||
| func addModuleInitFlags(startCmd *cobra.Command) { | ||
| crisis.AddModuleInitFlags(startCmd) | ||
| } | ||
|
|
||
| // genesisCommand builds genesis-related `simd genesis` command. Users may provide application specific commands as a parameter | ||
| func genesisCommand(txConfig client.TxConfig, basicManager module.BasicManager, cmds ...*cobra.Command) *cobra.Command { | ||
| cmd := genutilcli.Commands(txConfig, basicManager, app.DefaultNodeHome) | ||
|
|
||
| for _, subCmd := range cmds { | ||
| cmd.AddCommand(subCmd) | ||
| } | ||
| return cmd | ||
| } | ||
|
|
||
| func queryCommand() *cobra.Command { | ||
| cmd := &cobra.Command{ | ||
| Use: "query", | ||
| Aliases: []string{"q"}, | ||
| Short: "Querying subcommands", | ||
| DisableFlagParsing: false, | ||
| SuggestionsMinimumDistance: 2, | ||
| RunE: client.ValidateCmd, | ||
| } | ||
|
|
||
| cmd.AddCommand( | ||
| rpc.QueryEventForTxCmd(), | ||
| server.QueryBlockCmd(), | ||
| authcmd.QueryTxsByEventsCmd(), | ||
| server.QueryBlocksCmd(), | ||
| authcmd.QueryTxCmd(), | ||
| server.QueryBlockResultsCmd(), | ||
| ) | ||
|
|
||
| return cmd | ||
| } | ||
|
|
||
| func txCommand() *cobra.Command { | ||
| cmd := &cobra.Command{ | ||
| Use: "tx", | ||
| Short: "Transactions subcommands", | ||
| DisableFlagParsing: false, | ||
| SuggestionsMinimumDistance: 2, | ||
| RunE: client.ValidateCmd, | ||
| } | ||
|
|
||
| cmd.AddCommand( | ||
| authcmd.GetSignCommand(), | ||
| authcmd.GetSignBatchCommand(), | ||
| authcmd.GetMultiSignCommand(), | ||
| authcmd.GetMultiSignBatchCmd(), | ||
| authcmd.GetValidateSignaturesCommand(), | ||
| authcmd.GetBroadcastCommand(), | ||
| authcmd.GetEncodeCommand(), | ||
| authcmd.GetDecodeCommand(), | ||
| authcmd.GetSimulateCmd(), | ||
| ) | ||
|
|
||
| return cmd | ||
| } | ||
|
|
||
| // newApp creates the application | ||
| func newApp( | ||
| logger log.Logger, | ||
| db dbm.DB, | ||
| traceStore io.Writer, | ||
| appOpts servertypes.AppOptions, | ||
| ) servertypes.Application { | ||
| baseappOptions := server.DefaultBaseappOptions(appOpts) | ||
| return app.NewFnsaApp( | ||
| logger, db, traceStore, true, | ||
| appOpts, | ||
| baseappOptions..., | ||
| ) | ||
| } | ||
|
|
||
| // appExport creates a new simapp (optionally at a given height) and exports state. | ||
| func appExport( | ||
| logger log.Logger, | ||
| db dbm.DB, | ||
| traceStore io.Writer, | ||
| height int64, | ||
| forZeroHeight bool, | ||
| jailAllowedAddrs []string, | ||
| appOpts servertypes.AppOptions, | ||
| modulesToExport []string, | ||
| ) (servertypes.ExportedApp, error) { | ||
| // this check is necessary as we use the flag in x/upgrade. | ||
| // we can exit more gracefully by checking the flag here. | ||
| homePath, ok := appOpts.Get(flags.FlagHome).(string) | ||
| if !ok || homePath == "" { | ||
| return servertypes.ExportedApp{}, errors.New("application home not set") | ||
| } | ||
|
|
||
| viperAppOpts, ok := appOpts.(*viper.Viper) | ||
| if !ok { | ||
| return servertypes.ExportedApp{}, errors.New("appOpts is not viper.Viper") | ||
| } | ||
|
|
||
| // overwrite the FlagInvCheckPeriod | ||
| viperAppOpts.Set(server.FlagInvCheckPeriod, 1) | ||
| appOpts = viperAppOpts | ||
|
|
||
| var fnsaApp *app.FnsaApp | ||
| if height != -1 { | ||
| fnsaApp = app.NewFnsaApp(logger, db, traceStore, false, appOpts) | ||
|
|
||
| if err := fnsaApp.LoadHeight(height); err != nil { | ||
| return servertypes.ExportedApp{}, err | ||
| } | ||
| } else { | ||
| fnsaApp = app.NewFnsaApp(logger, db, traceStore, true, appOpts) | ||
| } | ||
|
|
||
| return fnsaApp.ExportAppStateAndValidators(forZeroHeight, jailAllowedAddrs, modulesToExport) | ||
| } | ||
|
|
||
| var tempDir = func() string { | ||
| dir, err := os.MkdirTemp("", "fnsad") | ||
| if err != nil { | ||
| dir = app.DefaultNodeHome | ||
| } | ||
| defer os.RemoveAll(dir) | ||
|
|
||
| return dir | ||
| } |
Oops, something went wrong.