fix: delete

wish · Apr 27, 2019 · 62c7f7d · 62c7f7d
1 parent 4684c7b
commit 62c7f7d
Show file tree

Hide file tree

Showing 2 changed files with 21 additions and 0 deletions.
diff --git a/pkg/kops/channel.go b/pkg/kops/channel.go
@@ -58,3 +58,18 @@ func generateChannel(ctx context.Context, c Channel, file string) error {
 
 	return nil
 }
+
+func deleteChannel(ctx context.Context, c Channel) error {
+	dest, err := vfs.Context.BuildVfsPath(c.Path)
+	if err != nil {
+		return err
+	}
+	if err := dest.Join(c.Name + ".yaml").Remove(); err != nil {
+		return err
+	}
+	if err := dest.Join(c.Name + ".json").Remove(); err != nil {
+		return err
+	}
+
+	return nil
+}
diff --git a/pkg/kops/update.go b/pkg/kops/update.go
@@ -40,6 +40,12 @@ func Delete(ctx context.Context, file string) (err error) {
 	if out.Kops == nil {
 		return fmt.Errorf("kops configuration is missing")
 	}
+	for _, c := range out.Kops.Channels {
+		err := deleteChannel(ctx, c)
+		if err != nil {
+			return fmt.Errorf("could not delete channel: %v", err)
+		}
+	}
 
 	kopsEnv := os.Environ()
 	for k, v := range out.Kops.Env {