-
Notifications
You must be signed in to change notification settings - Fork 547
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
feat: int in-place testnet creation (#4297)
- Loading branch information
1 parent
35b9a26
commit f7618d3
Showing
14 changed files
with
605 additions
and
2 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
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,24 @@ | ||
| package ignitecmd | ||
|
|
||
| import ( | ||
| "github.com/spf13/cobra" | ||
| ) | ||
|
|
||
| // NewTestnet returns a command that groups scaffolding related sub commands. | ||
| func NewTestnet() *cobra.Command { | ||
| c := &cobra.Command{ | ||
| Use: "testnet [command]", | ||
| Short: "Start a testnet local", | ||
| Long: `Start a testnet local | ||
| `, | ||
| Aliases: []string{"s"}, | ||
| Args: cobra.ExactArgs(1), | ||
| } | ||
|
|
||
| c.AddCommand( | ||
| NewTestnetInPlace(), | ||
| ) | ||
|
|
||
| return c | ||
| } |
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,129 @@ | ||
| package ignitecmd | ||
|
|
||
| import ( | ||
| sdk "github.com/cosmos/cosmos-sdk/types" | ||
|
|
||
| "github.com/spf13/cobra" | ||
|
|
||
| "github.com/ignite/cli/v29/ignite/pkg/cliui" | ||
| "github.com/ignite/cli/v29/ignite/pkg/cosmosaccount" | ||
| "github.com/ignite/cli/v29/ignite/pkg/errors" | ||
| "github.com/ignite/cli/v29/ignite/services/chain" | ||
| ) | ||
|
|
||
| func NewTestnetInPlace() *cobra.Command { | ||
| c := &cobra.Command{ | ||
| Use: "in-place", | ||
| Short: "Create and start a testnet from current local net state", | ||
| Long: `Testnet in-place command is used to create and start a testnet from current local net state(including mainnet). | ||
| After using this command in the repo containing the config.yml file, the network will start. | ||
| We can create a testnet from the local network state and mint additional coins for the desired accounts from the config.yml file.`, | ||
| Args: cobra.NoArgs, | ||
| RunE: testnetInPlaceHandler, | ||
| } | ||
| flagSetPath(c) | ||
| flagSetClearCache(c) | ||
| c.Flags().AddFlagSet(flagSetHome()) | ||
| c.Flags().AddFlagSet(flagSetCheckDependencies()) | ||
| c.Flags().AddFlagSet(flagSetSkipProto()) | ||
| c.Flags().AddFlagSet(flagSetVerbose()) | ||
|
|
||
| c.Flags().Bool(flagQuitOnFail, false, "quit program if the app fails to start") | ||
| return c | ||
| } | ||
|
|
||
| func testnetInPlaceHandler(cmd *cobra.Command, _ []string) error { | ||
| session := cliui.New( | ||
| cliui.WithVerbosity(getVerbosity(cmd)), | ||
| ) | ||
| defer session.End() | ||
|
|
||
| // Otherwise run the serve command directly | ||
| return testnetInplace(cmd, session) | ||
| } | ||
|
|
||
| func testnetInplace(cmd *cobra.Command, session *cliui.Session) error { | ||
| chainOption := []chain.Option{ | ||
| chain.WithOutputer(session), | ||
| chain.CollectEvents(session.EventBus()), | ||
| chain.CheckCosmosSDKVersion(), | ||
| } | ||
|
|
||
| if flagGetCheckDependencies(cmd) { | ||
| chainOption = append(chainOption, chain.CheckDependencies()) | ||
| } | ||
|
|
||
| // check if custom config is defined | ||
| config, _ := cmd.Flags().GetString(flagConfig) | ||
| if config != "" { | ||
| chainOption = append(chainOption, chain.ConfigFile(config)) | ||
| } | ||
|
|
||
| c, err := chain.NewWithHomeFlags(cmd, chainOption...) | ||
| if err != nil { | ||
| return err | ||
| } | ||
|
|
||
| cfg, err := c.Config() | ||
| if err != nil { | ||
| return err | ||
| } | ||
| home, err := c.Home() | ||
| if err != nil { | ||
| return err | ||
| } | ||
| keyringBackend, err := c.KeyringBackend() | ||
| if err != nil { | ||
| return err | ||
| } | ||
| ca, err := cosmosaccount.New( | ||
| cosmosaccount.WithKeyringBackend(cosmosaccount.KeyringBackend(keyringBackend)), | ||
| cosmosaccount.WithHome(home), | ||
| ) | ||
| if err != nil { | ||
| return err | ||
| } | ||
|
|
||
| var ( | ||
| operatorAddress sdk.ValAddress | ||
| accounts string | ||
| accErr *cosmosaccount.AccountDoesNotExistError | ||
| ) | ||
| for _, acc := range cfg.Accounts { | ||
| sdkAcc, err := ca.GetByName(acc.Name) | ||
| if errors.As(err, &accErr) { | ||
| sdkAcc, _, err = ca.Create(acc.Name) | ||
| } | ||
| if err != nil { | ||
| return err | ||
| } | ||
|
|
||
| sdkAddr, err := sdkAcc.Address(getAddressPrefix(cmd)) | ||
| if err != nil { | ||
| return err | ||
| } | ||
| if len(cfg.Validators) == 0 { | ||
| return errors.Errorf("no validators found for account %s", sdkAcc.Name) | ||
| } | ||
| if cfg.Validators[0].Name == acc.Name { | ||
| accAddr, err := sdk.AccAddressFromBech32(sdkAddr) | ||
| if err != nil { | ||
| return err | ||
| } | ||
| operatorAddress = sdk.ValAddress(accAddr) | ||
| } | ||
| accounts = accounts + "," + sdkAddr | ||
| } | ||
|
|
||
| chainID, err := c.ID() | ||
| if err != nil { | ||
| return err | ||
| } | ||
|
|
||
| args := chain.InPlaceArgs{ | ||
| NewChainID: chainID, | ||
| NewOperatorAddress: operatorAddress.String(), | ||
| AccountsToFund: accounts, | ||
| } | ||
| return c.TestnetInPlace(cmd.Context(), args) | ||
| } |
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,47 @@ | ||
| package chaincmd | ||
|
|
||
| import ( | ||
| "github.com/ignite/cli/v29/ignite/pkg/cmdrunner/step" | ||
| ) | ||
|
|
||
| type InPlaceOption func([]string) []string | ||
|
|
||
| func InPlaceWithPrvKey(prvKey string) InPlaceOption { | ||
| return func(s []string) []string { | ||
| if len(prvKey) > 0 { | ||
| return append(s, optionValidatorPrivateKey, prvKey) | ||
| } | ||
| return s | ||
| } | ||
| } | ||
|
|
||
| func InPlaceWithAccountToFund(accounts string) InPlaceOption { | ||
| return func(s []string) []string { | ||
| if len(accounts) > 0 { | ||
| return append(s, optionAccountToFund, accounts) | ||
| } | ||
| return s | ||
| } | ||
| } | ||
|
|
||
| func InPlaceWithSkipConfirmation() InPlaceOption { | ||
| return func(s []string) []string { | ||
| return append(s, optionSkipConfirmation) | ||
| } | ||
| } | ||
|
|
||
| // TestnetInPlaceCommand return command to start testnet in-place. | ||
| func (c ChainCmd) TestnetInPlaceCommand(newChainID, newOperatorAddress string, options ...InPlaceOption) step.Option { | ||
| command := []string{ | ||
| commandTestnetInPlace, | ||
| newChainID, | ||
| newOperatorAddress, | ||
| } | ||
|
|
||
| // Apply the options provided by the user | ||
| for _, apply := range options { | ||
| command = apply(command) | ||
| } | ||
|
|
||
| return c.daemonCommand(command) | ||
| } |
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,37 @@ | ||
| package chain | ||
|
|
||
| import ( | ||
| "context" | ||
| "os" | ||
|
|
||
| chainconfig "github.com/ignite/cli/v29/ignite/config/chain" | ||
| ) | ||
|
|
||
| type InPlaceArgs struct { | ||
| NewChainID string | ||
| NewOperatorAddress string | ||
| PrvKeyValidator string | ||
| AccountsToFund string | ||
| } | ||
|
|
||
| func (c Chain) TestnetInPlace(ctx context.Context, args InPlaceArgs) error { | ||
| commands, err := c.Commands(ctx) | ||
| if err != nil { | ||
| return err | ||
| } | ||
|
|
||
| // make sure that config.yml exists | ||
| if c.options.ConfigFile != "" { | ||
| if _, err := os.Stat(c.options.ConfigFile); err != nil { | ||
| return err | ||
| } | ||
| } else if _, err := chainconfig.LocateDefault(c.app.Path); err != nil { | ||
| return err | ||
| } | ||
|
|
||
| err = c.InPlace(ctx, commands, args) | ||
| if err != nil { | ||
| return err | ||
| } | ||
| return nil | ||
| } |
Oops, something went wrong.