feat(network): initialize init command

go.mod

@@ -52,7 +52,7 @@ require (
 	github.com/stretchr/testify v1.7.0
 	github.com/tendermint/flutter v1.0.2
 	github.com/tendermint/spm v0.1.7
-	github.com/tendermint/spn v0.1.1-0.20211019114618-71b787f1c6ba
+	github.com/tendermint/spn v0.1.1-0.20211104082149-b65147ba4d75
 	github.com/tendermint/tendermint v0.34.13
 	github.com/tendermint/vue v0.1.53
 	golang.org/x/mod v0.4.2

go.sum

@@ -1321,6 +1321,10 @@ github.com/tendermint/spm v0.1.7 h1:9PYX843H90im82WUr7EdZCQtyTKHthTIVrXsYCa8RBY=
 github.com/tendermint/spm v0.1.7/go.mod h1:d3w1LTzoBLb5A9WcgI+u/754tsIefCrnIOv7B+ynK9s=
 github.com/tendermint/spn v0.1.1-0.20211019114618-71b787f1c6ba h1:D+0eA/49vPFQ3QB4ElKLHM6buWrn/M5Cdfc/nS2ZiVY=
 github.com/tendermint/spn v0.1.1-0.20211019114618-71b787f1c6ba/go.mod h1:b9drKTa6ceWJ+6tT8Ujleta7GM7lnxAHyInGXyjP7CM=
+github.com/tendermint/spn v0.1.1-0.20211103092237-61b41bbb304a h1:Dd1XVHfKCxW/+7J0TiCxWF5MV7az/6wr3gqg47sZEgg=
+github.com/tendermint/spn v0.1.1-0.20211103092237-61b41bbb304a/go.mod h1:b9drKTa6ceWJ+6tT8Ujleta7GM7lnxAHyInGXyjP7CM=
+github.com/tendermint/spn v0.1.1-0.20211104082149-b65147ba4d75 h1:tRty0k6/WG4HmHMMpPfdAILhco2zfPVnisbgWTSVdLk=
+github.com/tendermint/spn v0.1.1-0.20211104082149-b65147ba4d75/go.mod h1:b9drKTa6ceWJ+6tT8Ujleta7GM7lnxAHyInGXyjP7CM=
 github.com/tendermint/tendermint v0.34.0-rc4/go.mod h1:yotsojf2C1QBOw4dZrTcxbyxmPUrT4hNuOQWX9XUwB4=
 github.com/tendermint/tendermint v0.34.0-rc6/go.mod h1:ugzyZO5foutZImv0Iyx/gOFCX6mjJTgbLHTwi17VDVg=
 github.com/tendermint/tendermint v0.34.0/go.mod h1:Aj3PIipBFSNO21r+Lq3TtzQ+uKESxkbA3yo/INM4QwQ=

starport/cmd/cmd.go

@@ -15,6 +15,7 @@ import (
 	flag "github.com/spf13/pflag"
 	"github.com/tendermint/starport/starport/internal/version"
 	"github.com/tendermint/starport/starport/pkg/clispinner"
+	"github.com/tendermint/starport/starport/pkg/cosmosaccount"
 	"github.com/tendermint/starport/starport/pkg/cosmosver"
 	"github.com/tendermint/starport/starport/pkg/events"
 	"github.com/tendermint/starport/starport/pkg/gitpod"
@@ -110,6 +111,12 @@ func flagSetHome() *flag.FlagSet {
 	return fs
 }
 
+func flagNetworkFrom() *flag.FlagSet {
+	fs := flag.NewFlagSet("", flag.ContinueOnError)
+	fs.String(flagFrom, cosmosaccount.DefaultAccount, "Account name to use for sending transactions to SPN")
+	return fs
+}
+
 func getHome(cmd *cobra.Command) (home string) {
 	home, _ = cmd.Flags().GetString(flagHome)
 	return

starport/cmd/network_chain.go

@@ -10,7 +10,10 @@ func NewNetworkChain() *cobra.Command {
 		Short: "Build networks",
 	}
 
-	c.AddCommand(NewNetworkChainPublish())
+	c.AddCommand(
+		NewNetworkChainPublish(),
+		NewNetworkChainInit(),
+	)
 
 	return c
 }

starport/cmd/network_chain_init.go

@@ -0,0 +1,193 @@
+package starportcmd
+
+import (
+	"fmt"
+	"os"
+	"strconv"
+	"sync"
+
+	"github.com/manifoldco/promptui"
+	"github.com/spf13/cobra"
+	"github.com/tendermint/starport/starport/pkg/cliquiz"
+	"github.com/tendermint/starport/starport/pkg/clispinner"
+	"github.com/tendermint/starport/starport/pkg/events"
+	"github.com/tendermint/starport/starport/services/chain"
+	"github.com/tendermint/starport/starport/services/network"
+)
+
+const (
+	flagRecover  = "recover"
+	flagMnemonic = "mnemonic"
+	flagKeyName  = "key-name"
+)
+
+// NewNetworkChainInit returns a new command to initialize a chain from a published chain ID
+func NewNetworkChainInit() *cobra.Command {
+	c := &cobra.Command{
+		Use:   "init [launch-id]",
+		Short: "Initialize a chain from a published chain ID",
+		Args:  cobra.ExactArgs(1),
+		RunE:  networkChainInitHandler,
+	}
+
+	c.Flags().Bool(flagRecover, false, "Recover chain account from a mnemonic")
+	c.Flags().String(flagMnemonic, "", "Mnemonic for recovered account")
+	c.Flags().String(flagKeyName, "", "key name for the chain account")
+
+	c.Flags().AddFlagSet(flagNetworkFrom())
+	c.Flags().AddFlagSet(flagSetHome())
+	c.Flags().AddFlagSet(flagSetKeyringBackend())
+	c.Flags().AddFlagSet(flagSetYes())
+
+	return c
+}
+
+func networkChainInitHandler(cmd *cobra.Command, args []string) error {
+	var (
+		recover, _  = cmd.Flags().GetBool(flagRecover)
+		mnemonic, _ = cmd.Flags().GetString(flagMnemonic)
+		keyName, _  = cmd.Flags().GetString(flagKeyName)
+	)
+
+	s := clispinner.New()
+	defer s.Stop()
+
+	var (
+		wg sync.WaitGroup
+		ev = events.NewBus()
+	)
+	wg.Add(1)
+
+	defer wg.Wait()
+	defer ev.Shutdown()
+
+	go printEvents(&wg, ev, s)
+
+	// parse launch ID
+	launchID, err := strconv.ParseUint(args[0], 10, 64)
+	if err != nil {
+		return fmt.Errorf("error parsing launchID: %s", err.Error())
+	}
+
+	// if a chain has already been initialized with this launch ID, we ask for confirmation before erasing the directory
+	chainHome, exist, err := checkChainHomeExist(launchID)
+	if err != nil {
+		return err
+	}
+	if !getYes(cmd) && exist {
+		prompt := promptui.Prompt{
+			Label: fmt.Sprintf("The chain has already been initialized under: %s. Would you like to overwrite the home directory",
+				chainHome,
+			),
+			IsConfirm: true,
+		}
+		s.Stop()
+		if _, err := prompt.Run(); err != nil {
+			fmt.Println("said no")
+			return nil
+		}
+		s.Start()
+	}
+
+	nb, err := newNetwork(cmd, network.CollectEvents(ev))
+	if err != nil {
+		return err
+	}
+
+	// initialize the blockchain from the launch ID
+	initOptions := initOptionWithHomeFlag(cmd, []network.InitOption{network.MustNotInitializedBefore()})
+	sourceOption := network.SourceLaunchID(launchID)
+	blockchain, err := nb.Blockchain(cmd.Context(), sourceOption, initOptions...)
+	if err != nil {
+		return err
+	}
+
+	if err := blockchain.Init(cmd.Context()); err != nil {
+		return err
+	}
+
+	// ask validator information
+	v, err := askValidatorInfo()
+	if err != nil {
+		return err
+	}
+
+	// ask user for mnemonic if not provided and recover option defined
+	if mnemonic == "" && recover {
+		cliquiz.Ask(cliquiz.NewQuestion("Enter your account mnemonic",
+			&mnemonic,
+			cliquiz.DefaultAnswer(""),
+			cliquiz.Required(),
+		))
+	}
+
+	acc, gentxPath, err := blockchain.InitAccount(cmd.Context(), v, keyName, mnemonic)
+	if err != nil {
+		return err
+	}
+	fmt.Printf(`Account created
+Address: %s
+Mnemonic: %s
+`, acc.Address, acc.Mnemonic)
+	fmt.Printf("Gentx generated: %s\n", gentxPath)
+
+	return nil
+}
+
+// askValidatorInfo prompts to the user questions to query validator information
+func askValidatorInfo() (v chain.Validator, err error) {
+	questions := append([]cliquiz.Question{},
+		cliquiz.NewQuestion("Staking amount",
+			&v.StakingAmount,
+			cliquiz.DefaultAnswer("95000000stake"),
+			cliquiz.Required(),
+		),
+		cliquiz.NewQuestion("Moniker",
+			&v.Moniker,
+			cliquiz.DefaultAnswer("mynode"),
+			cliquiz.Required(),
+		),
+		cliquiz.NewQuestion("Commission rate",
+			&v.CommissionRate,
+			cliquiz.DefaultAnswer("0.10"),
+			cliquiz.Required(),
+		),
+		cliquiz.NewQuestion("Commission max rate",
+			&v.CommissionMaxRate,
+			cliquiz.DefaultAnswer("0.20"),
+			cliquiz.Required(),
+		),
+		cliquiz.NewQuestion("Commission max change rate",
+			&v.CommissionMaxChangeRate,
+			cliquiz.DefaultAnswer("0.01"),
+			cliquiz.Required(),
+		),
+		cliquiz.NewQuestion("Min self delegation",
+			&v.MinSelfDelegation,
+			cliquiz.DefaultAnswer("1"),
+			cliquiz.Required(),
+		),
+		cliquiz.NewQuestion("Gas prices",
+			&v.GasPrices,
+			cliquiz.DefaultAnswer("0.025stake"),
+			cliquiz.Required(),
+		),
+		cliquiz.NewQuestion("Details", &v.Details),
+		cliquiz.NewQuestion("Identity", &v.Identity),
+		cliquiz.NewQuestion("Website", &v.Website),
+	)
+	return v, cliquiz.Ask(questions...)
+}
+
+// checkChainHomeExist checks if a home with the provided launchID already exist
+func checkChainHomeExist(launchID uint64) (string, bool, error) {
+	home, err := network.ChainHome(launchID)
+	if err != nil {
+		return home, false, err
+	}
+
+	if _, err := os.Stat(home); os.IsNotExist(err) {
+		return home, false, nil
+	}
+	return home, true, err
+}

starport/cmd/network_chain_publish.go

@@ -7,7 +7,6 @@ import (
 	"github.com/manifoldco/promptui"
 	"github.com/spf13/cobra"
 	"github.com/tendermint/starport/starport/pkg/clispinner"
-	"github.com/tendermint/starport/starport/pkg/cosmosaccount"
 	"github.com/tendermint/starport/starport/pkg/events"
 	"github.com/tendermint/starport/starport/pkg/xurl"
 	"github.com/tendermint/starport/starport/services/network"
@@ -35,7 +34,7 @@ func NewNetworkChainPublish() *cobra.Command {
 	c.Flags().String(flagHash, "", "Git hash to use for the repo")
 	c.Flags().String(flagGenesis, "", "URL to a custom Genesis")
 	c.Flags().Bool(flagNoCheck, false, "Skip verifying chain's integrity")
-	c.Flags().String(flagFrom, cosmosaccount.DefaultAccount, "Account name to use for sending transactions to SPN")
+	c.Flags().AddFlagSet(flagNetworkFrom())
 	c.Flags().AddFlagSet(flagSetKeyringBackend())
 	c.Flags().AddFlagSet(flagSetHome())
 	c.Flags().AddFlagSet(flagSetYes())

starport/pkg/chaincmd/chaincmd.go

@@ -36,6 +36,9 @@ const (
 	optionValidatorCommissionMaxChangeRate = "--commission-max-change-rate"
 	optionValidatorMinSelfDelegation       = "--min-self-delegation"
 	optionValidatorGasPrices               = "--gas-prices"
+	optionValidatorDetails                 = "--details"
+	optionValidatorIdentity                = "--identity"
+	optionValidatorWebsite                 = "--website"
 	optionYes                              = "--yes"
 	optionHomeClient                       = "--home-client"
 	optionCoinType                         = "--coin-type"
@@ -325,6 +328,36 @@ func GentxWithGasPrices(gasPrices string) GentxOption {
 	}
 }
 
+// GentxWithDetails provides validator details option for the gentx command
+func GentxWithDetails(details string) GentxOption {
+	return func(command []string) []string {
+		if len(details) > 0 {
+			return append(command, optionValidatorDetails, details)
+		}
+		return command
+	}
+}
+
+// GentxWithIdentity provides validator identity option for the gentx command
+func GentxWithIdentity(identity string) GentxOption {
+	return func(command []string) []string {
+		if len(identity) > 0 {
+			return append(command, optionValidatorIdentity, identity)
+		}
+		return command
+	}
+}
+
+// GentxWithWebsite provides validator website option for the gentx command
+func GentxWithWebsite(website string) GentxOption {
+	return func(command []string) []string {
+		if len(website) > 0 {
+			return append(command, optionValidatorWebsite, website)
+		}
+		return command
+	}
+}
+
 func (c ChainCmd) IsAutoChainIDDetectionEnabled() bool {
 	return c.isAutoChainIDDetectionEnabled
 }

starport/services/chain/init.go

@@ -167,20 +167,28 @@ func (c *Chain) InitAccounts(ctx context.Context, conf chainconfig.Config) error
 		}
 	}
 
-	// create the gentx from the validator from the config
-	if _, err := c.plugin.Gentx(ctx, commands, Validator{
+	_, err = c.IssueGentx(ctx, Validator{
 		Name:          conf.Validator.Name,
 		StakingAmount: conf.Validator.Staked,
-	}); err != nil {
-		return err
+	})
+	return err
+}
+
+// IssueGentx generates a gentx from the validator information in chain config and import it in the chain genesis
+func (c Chain) IssueGentx(ctx context.Context, v Validator) (string, error) {
+	commands, err := c.Commands(ctx)
+	if err != nil {
+		return "", err
 	}
 
-	// import the gentx into the genesis
-	if err := commands.CollectGentxs(ctx); err != nil {
-		return err
+	// create the gentx from the validator from the config
+	gentxPath, err := c.plugin.Gentx(ctx, commands, v)
+	if err != nil {
+		return "", err
 	}
 
-	return nil
+	// import the gentx into the genesis
+	return gentxPath, commands.CollectGentxs(ctx)
 }
 
 // IsInitialized checks if the chain is initialized
@@ -212,6 +220,9 @@ type Validator struct {
 	CommissionMaxChangeRate string
 	MinSelfDelegation       string
 	GasPrices               string
+	Details                 string
+	Identity                string
+	Website                 string
 }
 
 // Account represents an account in the chain.

starport/services/chain/plugin-stargate.go

@@ -38,6 +38,9 @@ func (p *stargatePlugin) Gentx(ctx context.Context, runner chaincmdrunner.Runner
 		chaincmd.GentxWithCommissionMaxChangeRate(v.CommissionMaxChangeRate),
 		chaincmd.GentxWithMinSelfDelegation(v.MinSelfDelegation),
 		chaincmd.GentxWithGasPrices(v.GasPrices),
+		chaincmd.GentxWithDetails(v.Details),
+		chaincmd.GentxWithIdentity(v.Identity),
+		chaincmd.GentxWithWebsite(v.Website),
 	)
 }