Jay/chef 4487

components/automate-cli/cmd/chef-automate/automateHAAwsDeployment.go

@@ -45,6 +45,13 @@ func newAwsDeployemnt(configPath string) *awsDeployment {
 
 func (a *awsDeployment) doDeployWork(args []string) error {
 	if isA2HARBFileExist() {
+		if !deployCmdFlags.skipVerify {
+			_, configFile := getConfigFileFromArgs(args)
+			err := executeConfigVerifyAndPromptConfirmationOnError(configFile)
+			if err != nil {
+				return err
+			}
+		}
 		err := a.generateConfig(DEPLOY)
 		if err != nil {
 			return status.Annotate(err, status.DeployError)

components/automate-cli/cmd/chef-automate/automateHADeployExistingInfra.go

@@ -30,7 +30,14 @@ func newExistingInfa(configPath string) *existingInfra {
 }
 
 func (e *existingInfra) doDeployWork(args []string) error {
-	var err = bootstrapEnv(e, deployCmdFlags.airgap, false, DEPLOY)
+	if !deployCmdFlags.skipVerify {
+		_, configFile := getConfigFileFromArgs(args)
+		err := executeConfigVerifyAndPromptConfirmationOnError(configFile)
+		if err != nil {
+			return err
+		}
+	}
+	err := bootstrapEnv(e, deployCmdFlags.airgap, false, DEPLOY)
 	if err != nil {
 		return err
 	}

components/automate-cli/cmd/chef-automate/cliUtils.go

@@ -2,8 +2,18 @@ package main
 
 import (
 	"fmt"
+	"os"
 	"strings"
 
+	"github.com/chef/automate/components/automate-cli/pkg/status"
+	"github.com/chef/automate/components/automate-cli/pkg/verifysystemdcreate"
+	"github.com/chef/automate/lib/config"
+	"github.com/chef/automate/lib/httputils"
+	"github.com/chef/automate/lib/io/fileutils"
+	"github.com/chef/automate/lib/logger"
+	"github.com/chef/automate/lib/platform/command"
+	"github.com/chef/automate/lib/pmt"
+	"github.com/chef/automate/lib/sshutils"
 	"github.com/pkg/errors"
 	"github.com/spf13/cobra"
 	"github.com/spf13/pflag"
@@ -108,3 +118,44 @@ func GetEnabledFlags(cmd *cobra.Command, flagsToIgnore map[string]int) string {
 	})
 	return flags
 }
+
+func executeConfigVerify(configFile string) error {
+
+	log, err := logger.NewLogger("text", "info")
+	if err != nil {
+		return err
+	}
+
+	createSystemdServiceWithBinary, err := verifysystemdcreate.NewCreateSystemdService(
+		verifysystemdcreate.NewSystemdCreateUtilsImpl(),
+		BINARY_DESTINATION_FOLDER,
+		SYSTEMD_PATH,
+		false,
+		writer,
+	)
+	if err != nil {
+		return err
+	}
+	deps := &verifyCmdDeps{
+		getAutomateHAInfraDetails: getAutomateHAInfraDetails,
+		PopulateHaCommonConfig:    PopulateHaCommonConfig,
+	}
+	c := NewVerifyCmdFlow(httputils.NewClient(log), createSystemdServiceWithBinary, verifysystemdcreate.NewSystemdCreateUtilsImpl(), config.NewHaDeployConfig(), sshutils.NewSSHUtilWithCommandExecutor(sshutils.NewSshClient(), log, command.NewExecExecutor()), writer, deps)
+	return c.RunVerify(configFile)
+}
+func executeConfigVerifyAndPromptConfirmationOnError(configFile string) error {
+	err := executeConfigVerify(configFile)
+	if err != nil {
+		fsu := fileutils.NewFileSystemUtils()
+		p := pmt.PromptFactory(os.Stdin, os.Stdout, fsu)
+		ok, err := p.Confirm("Config verification failed. Do you still wan to continue?", "yes", "no")
+		if err != nil {
+			return status.Wrap(err, status.PromptFailed, err.Error())
+		}
+		if !ok {
+			err = errors.New("failed to confirm overwrite")
+			return status.Annotate(err, status.ConfigVerifyError)
+		}
+	}
+	return nil
+}

components/automate-cli/cmd/chef-automate/deploy.go

@@ -64,6 +64,7 @@ var deployCmdFlags = struct {
 	bootstrapBundlePath             string
 	userAuth                        bool
 	saas                            bool
+	skipVerify                      bool
 }{}
 
 // deployCmd represents the new command
@@ -184,6 +185,12 @@ func newDeployCmd() *cobra.Command {
 		"y",
 		false,
 		"Do not prompt for confirmation; accept defaults and continue")
+	cmd.PersistentFlags().BoolVarP(
+		&deployCmdFlags.skipVerify,
+		"skip-verify",
+		"",
+		false,
+		"Flag for skipping config verification check")
 
 	if !isDevMode() {
 		for _, flagName := range []string{

components/automate-cli/cmd/chef-automate/deployHa.go

@@ -9,17 +9,23 @@ import (
 )
 
 func executeDeployment(args []string) error {
+	indexOfConfig, _ := getConfigFileFromArgs(args)
+	args = append(args[:indexOfConfig], args[indexOfConfig+1:]...)
+	args = append(args, "-y")
+	if isA2HARBFileExist() {
+		return executeAutomateClusterCtlCommandAsync("deploy", args, automateHADeployHelpDocs, true)
+	}
+	return errors.New(AUTOMATE_HA_INVALID_BASTION)
+}
+func getConfigFileFromArgs(args []string) (int, string) {
 	var indexOfConfig = 0
+	var configFile = ""
 	for i, a := range args {
 		if strings.Contains(a, ".toml") {
+			configFile = a
 			indexOfConfig = i
 			break
 		}
 	}
-	args = append(args[:indexOfConfig], args[indexOfConfig+1:]...)
-	args = append(args, "-y")
-	if isA2HARBFileExist() {
-		return executeAutomateClusterCtlCommandAsync("deploy", args, automateHADeployHelpDocs, true)
-	}
-	return errors.New(AUTOMATE_HA_INVALID_BASTION)
+	return indexOfConfig, configFile
 }

components/automate-cli/cmd/chef-automate/upgrade.go

@@ -54,6 +54,7 @@ var upgradeRunCmdFlags = struct {
 	acceptMLSA           bool
 	upgradeHAWorkspace   string
 	saas                 bool
+	skipVerify           bool
 }{}
 
 var upgradeRunCmd = &cobra.Command{
@@ -385,6 +386,12 @@ func restartDeploymentService() error {
 }
 
 func runAutomateHAFlow(args []string, offlineMode bool) error {
+	if !upgradeRunCmdFlags.skipVerify {
+		err := executeConfigVerifyAndPromptConfirmationOnError("")
+		if err != nil {
+			return err
+		}
+	}
 	isManagedServices := isManagedServicesOn()
 	if isManagedServices && !upgradeRunCmdFlags.upgradefrontends {
 		return status.Annotate(
@@ -966,6 +973,14 @@ func init() {
 		command.Parent().HelpFunc()(command, strings)
 	})
 
+	upgradeRunCmd.PersistentFlags().BoolVarP(
+		&upgradeRunCmdFlags.skipVerify,
+		"skip-verify",
+		"",
+		false,
+		"Flag for skipping config verification check")
+	upgradeRunCmd.PersistentFlags().SetAnnotation("skip-storage-check", docs.Compatibility, []string{docs.CompatiblewithStandalone})
+
 	if !isDevMode() {
 		err := upgradeStatusCmd.PersistentFlags().MarkHidden("versions-file")
 		if err != nil {