Force flag

cmd/tarmak/cmd/root.go

@@ -105,6 +105,14 @@ func init() {
 		"override the current cluster set in the config",
 	)
 
+	RootCmd.PersistentFlags().BoolVarP(
+		&globalFlags.Force,
+		"force",
+		"f",
+		false,
+		"skip all validation and verification checks",
+	)
+
 	if version == "dev" {
 		RootCmd.PersistentFlags().BoolVar(
 			&globalFlags.WingDevMode,

pkg/apis/tarmak/v1alpha1/types.go

@@ -127,6 +127,8 @@ type Flags struct {
 	Version string // expose tarmak's build time version
 
 	WingDevMode bool // use a bundled wing version rather than a tagged release from GitHub
+
+	Force bool // skip all validations and verification
 }
 
 // This contains the cluster specifc operation flags

pkg/tarmak/cluster/cluster.go

@@ -55,8 +55,10 @@ func NewFromConfig(environment interfaces.Environment, conf *clusterv1alpha1.Clu
 		log:         environment.Log().WithField("cluster", conf.Name),
 	}
 
-	if err := cluster.Validate(); err != nil {
-		return nil, err
+	if !environment.Tarmak().Config().Force() {
+		if err := cluster.Validate(); err != nil {
+			return nil, err
+		}
 	}
 
 	cluster.roles = make(map[string]*role.Role)

pkg/tarmak/cluster/cluster_test.go

@@ -60,6 +60,8 @@ func newFakeCluster(t *testing.T, cluster *clusterv1alpha1.Cluster) *fakeCluster
 	c.fakeProvider.EXPECT().Cloud().Return("provider").AnyTimes()
 	c.fakeProvider.EXPECT().Name().Return("provider-name").AnyTimes()
 
+	c.fakeConfig.EXPECT().Force().Return(false).AnyTimes()
+
 	c.fakeTarmak.EXPECT().Config().AnyTimes().Return(c.fakeConfig)
 
 	return c

pkg/tarmak/config/config.go

@@ -351,3 +351,7 @@ func (c *Config) Project() string {
 func (c *Config) WingDevMode() bool {
 	return c.flags.WingDevMode
 }
+
+func (c *Config) Force() bool {
+	return c.flags.Force
+}

pkg/tarmak/interfaces/interfaces.go

@@ -184,6 +184,7 @@ type Config interface {
 	Project() string
 	WingDevMode() bool
 	SetCurrentCluster(string) error
+	Force() bool
 }
 
 type Packer interface {

pkg/tarmak/kubectl/kubectl.go

@@ -49,8 +49,10 @@ func (k *Kubectl) requestNewAdminCert(cluster *api.Cluster, authInfo *api.AuthIn
 
 	k.log.Infof("request new certificate from vault (%s)", path)
 
-	if err := k.tarmak.Cluster().Environment().Validate(); err != nil {
-		k.log.Fatal("could not validate config: ", err)
+	if !k.tarmak.Config().Force() {
+		if err := k.tarmak.Cluster().Environment().Validate(); err != nil {
+			k.log.Fatal("could not validate config: ", err)
+		}
 	}
 
 	vault := k.tarmak.Environment().Vault()

pkg/tarmak/tarmak.go

@@ -281,10 +281,9 @@ func (t *Tarmak) Version() string {
 }
 
 func (t *Tarmak) Validate() error {
-	var err error
-	var result error
+	var result *multierror.Error
 
-	err = t.Cluster().Validate()
+	err := t.Cluster().Validate()
 	if err != nil {
 		result = multierror.Append(result, err)
 	}
@@ -294,7 +293,7 @@ func (t *Tarmak) Validate() error {
 		result = multierror.Append(result, err)
 	}
 
-	return result
+	return result.ErrorOrNil()
 }
 
 func (t *Tarmak) Verify() error {

pkg/tarmak/tarmak_test.go

@@ -64,6 +64,7 @@ func (tt *testTarmak) fakeAWSProvider(name string) {
 	}
 
 	tt.fakeConfig.EXPECT().Provider(name).AnyTimes().Return(&tarmakv1alpha1.Provider{}, nil)
+	tt.fakeConfig.EXPECT().Force().Return(false).AnyTimes()
 }
 
 func (tt *testTarmak) addEnvironment(env *tarmakv1alpha1.Environment) {

pkg/tarmak/terraform.go

@@ -14,14 +14,16 @@ func (t *Tarmak) Terraform() interfaces.Terraform {
 }
 
 func (t *Tarmak) CmdTerraformPlan(args []string, ctx context.Context) error {
-	t.cluster.Log().Info("validate steps")
-	if err := t.Validate(); err != nil {
-		return fmt.Errorf("failed to validate tarmak: %s", err)
-	}
+	if !t.Config().Force() {
+		t.cluster.Log().Info("validate steps")
+		if err := t.Validate(); err != nil {
+			return fmt.Errorf("failed to validate tarmak: %s", err)
+		}
 
-	t.cluster.Log().Info("verify steps")
-	if err := t.Verify(); err != nil {
-		return err
+		t.cluster.Log().Info("verify steps")
+		if err := t.Verify(); err != nil {
+			return err
+		}
 	}
 
 	t.cluster.Log().Info("write SSH config")
@@ -39,14 +41,16 @@ func (t *Tarmak) CmdTerraformPlan(args []string, ctx context.Context) error {
 }
 
 func (t *Tarmak) CmdTerraformApply(args []string, ctx context.Context) error {
-	t.cluster.Log().Info("validate steps")
-	if err := t.Validate(); err != nil {
-		return fmt.Errorf("failed to validate tarmak: %s", err)
-	}
+	if !t.Config().Force() {
+		t.cluster.Log().Info("validate steps")
+		if err := t.Validate(); err != nil {
+			return fmt.Errorf("failed to validate tarmak: %s", err)
+		}
 
-	t.cluster.Log().Info("verify steps")
-	if err := t.Verify(); err != nil {
-		return err
+		t.cluster.Log().Info("verify steps")
+		if err := t.Verify(); err != nil {
+			return err
+		}
 	}
 
 	t.cluster.Log().Info("write SSH config")
@@ -89,14 +93,16 @@ func (t *Tarmak) CmdTerraformApply(args []string, ctx context.Context) error {
 }
 
 func (t *Tarmak) CmdTerraformDestroy(args []string, ctx context.Context) error {
-	t.cluster.Log().Info("validate steps")
-	if err := t.Validate(); err != nil {
-		return fmt.Errorf("failed to validate tarmak: %s", err)
-	}
+	if !t.Config().Force() {
+		t.cluster.Log().Info("validate steps")
+		if err := t.Validate(); err != nil {
+			return fmt.Errorf("failed to validate tarmak: %s", err)
+		}
 
-	t.cluster.Log().Info("verify steps")
-	if err := t.Verify(); err != nil {
-		return err
+		t.cluster.Log().Info("verify steps")
+		if err := t.Verify(); err != nil {
+			return err
+		}
 	}
 
 	t.cluster.Log().Info("write SSH config")