-
Notifications
You must be signed in to change notification settings - Fork 6
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
1 parent
6afce4e
commit 0c9f907
Showing
55 changed files
with
1,081 additions
and
81 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
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -1,4 +1,4 @@ | ||
| tokend | ||
| bin/tokend | ||
| debug_container.dot | ||
| debug_container.log | ||
|
|
||
|
|
||
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
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
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
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,279 @@ | ||
| package cmd | ||
|
|
||
| import ( | ||
| "errors" | ||
| "io" | ||
| "os" | ||
|
|
||
| "github.com/CosmWasm/wasmd/x/wasm" | ||
| wasmcli "github.com/CosmWasm/wasmd/x/wasm/client/cli" | ||
| wasmkeeper "github.com/CosmWasm/wasmd/x/wasm/keeper" | ||
| "github.com/prometheus/client_golang/prometheus" | ||
| "github.com/reecepbcups/tokenfactory/app" | ||
| "github.com/spf13/cast" | ||
| "github.com/spf13/cobra" | ||
| "github.com/spf13/viper" | ||
|
|
||
| cmtcfg "github.com/cometbft/cometbft/config" | ||
|
|
||
| dbm "github.com/cosmos/cosmos-db" | ||
|
|
||
| "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/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" | ||
| ) | ||
|
|
||
| // 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. | ||
|
|
||
| // WASMConfig defines configuration for the wasm module. | ||
| type WASMConfig struct { | ||
| // This is the maximum sdk gas (wasm and storage) that we allow for any x/wasm "smart" queries | ||
| QueryGasLimit uint64 `mapstructure:"query_gas_limit"` | ||
|
|
||
| // Address defines the gRPC-web server to listen on | ||
| LruSize uint64 `mapstructure:"lru_size"` | ||
| } | ||
|
|
||
| type CustomAppConfig struct { | ||
| serverconfig.Config `mapstructure:",squash"` | ||
|
|
||
| WASM WASMConfig `mapstructure:"wasm"` | ||
| } | ||
|
|
||
| // 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. | ||
| // | ||
| // In simapp, we set the min gas prices to 0. | ||
| srvCfg.MinGasPrices = "0stake" | ||
| // srvCfg.BaseConfig.IAVLDisableFastNode = true // disable fastnode by default | ||
|
|
||
| customAppConfig := CustomAppConfig{ | ||
| Config: *srvCfg, | ||
| WASM: WASMConfig{ | ||
| LruSize: 1, | ||
| QueryGasLimit: 300000, | ||
| }, | ||
| } | ||
|
|
||
| customAppTemplate := serverconfig.DefaultConfigTemplate + ` | ||
| [wasm] | ||
| # This is the maximum sdk gas (wasm and storage) that we allow for any x/wasm "smart" queries | ||
| query_gas_limit = {{ .WASM.QueryGasLimit }} | ||
| # This is the number of wasm vm instances we keep cached in memory for speed-up | ||
| # Warning: this is currently unstable and may lead to crashes, best to keep for 0 unless testing locally | ||
| lru_size = {{ .WASM.LruSize }} | ||
| ` | ||
|
|
||
| return customAppTemplate, customAppConfig | ||
| } | ||
|
|
||
| func initRootCmd( | ||
| rootCmd *cobra.Command, | ||
| txConfig client.TxConfig, | ||
| // interfaceRegistry codectypes.InterfaceRegistry, | ||
| // appCodec 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) | ||
| wasmcli.ExtendUnsafeResetAllCmd(rootCmd) | ||
|
|
||
| // 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) | ||
| wasm.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) | ||
|
|
||
| var wasmOpts []wasmkeeper.Option | ||
| if cast.ToBool(appOpts.Get("telemetry.enabled")) { | ||
| wasmOpts = append(wasmOpts, wasmkeeper.WithVMCacheMetrics(prometheus.DefaultRegisterer)) | ||
| } | ||
|
|
||
| return app.NewApp( | ||
| logger, db, traceStore, true, | ||
| appOpts, | ||
| wasmOpts, | ||
| baseappOptions..., | ||
| ) | ||
| } | ||
|
|
||
| // appExport creates a new wasm app (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) { | ||
| var chainApp *app.TokenFactoryApp | ||
| // 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 emptyWasmOpts []wasmkeeper.Option | ||
|
|
||
| if height != -1 { | ||
| chainApp = app.NewApp(logger, db, traceStore, false, appOpts, emptyWasmOpts) | ||
|
|
||
| if err := chainApp.LoadHeight(height); err != nil { | ||
| return servertypes.ExportedApp{}, err | ||
| } | ||
| } else { | ||
| chainApp = app.NewApp(logger, db, traceStore, true, appOpts, emptyWasmOpts) | ||
| } | ||
|
|
||
| return chainApp.ExportAppStateAndValidators(forZeroHeight, jailAllowedAddrs, modulesToExport) | ||
| } | ||
|
|
||
| var tempDir = func() string { | ||
| dir, err := os.MkdirTemp("", "manifest") | ||
| if err != nil { | ||
| dir = app.DefaultNodeHome | ||
| } | ||
| defer os.RemoveAll(dir) | ||
|
|
||
| return dir | ||
| } |
Oops, something went wrong.