Add coder envs rm command for removing environments

cmoog · cmoog · commit 9dcf1b94433b · 2020-10-20T23:58:50.000-05:00
diff --git a/docs/coder_envs.md b/docs/coder_envs.md
@@ -23,4 +23,5 @@ Perform operations on the Coder environments owned by the active user.
 
 * [coder](coder.md)	 - coder provides a CLI for working with an existing Coder Enterprise installation
 * [coder envs ls](coder_envs_ls.md)	 - list all environments owned by the active user
+* [coder envs rm](coder_envs_rm.md)	 - remove Coder environments by name
 * [coder envs stop](coder_envs_stop.md)	 - stop Coder environments by name
diff --git a/docs/coder_envs_rm.md b/docs/coder_envs_rm.md
@@ -0,0 +1,29 @@
+## coder envs rm
+
+remove Coder environments by name
+
+### Synopsis
+
+remove Coder environments by name
+
+```
+coder envs rm [...environment_names] [flags]
+```
+
+### Options
+
+```
+  -f, --force   force remove the specified environments without prompting first
+  -h, --help    help for rm
+```
+
+### Options inherited from parent commands
+
+```
+      --user string   Specify the user whose resources to target (default "me")
+  -v, --verbose       show verbose output
+```
+
+### SEE ALSO
+
+* [coder envs](coder_envs.md)	 - Interact with Coder environments
diff --git a/internal/cmd/envs.go b/internal/cmd/envs.go
@@ -2,19 +2,21 @@ package cmd
 
 import (
 	"encoding/json"
+	"fmt"
 	"os"
 
 	"cdr.dev/coder-cli/coder-sdk"
 	"cdr.dev/coder-cli/internal/x/xtabwriter"
+	"github.com/manifoldco/promptui"
 	"github.com/spf13/cobra"
 	"golang.org/x/sync/errgroup"
+	"golang.org/x/sync/semaphore"
 	"golang.org/x/xerrors"
 
 	"go.coder.com/flog"
 )
 
 func envsCommand() *cobra.Command {
-	var outputFmt string
 	var user string
 	cmd := &cobra.Command{
 		Use:   "envs",
@@ -23,7 +25,20 @@ func envsCommand() *cobra.Command {
 	}
 	cmd.PersistentFlags().StringVar(&user, "user", coder.Me, "Specify the user whose resources to target")
 
-	lsCmd := &cobra.Command{
+	cmd.AddCommand(
+		lsEnvsCommand(&user),
+		stopEnvsCommand(&user),
+		rmEnvsCommand(&user),
+		watchBuildLogCommand(),
+		rebuildEnvCommand(),
+	)
+	return cmd
+}
+
+func lsEnvsCommand(user *string) *cobra.Command {
+	var outputFmt string
+
+	cmd := &cobra.Command{
 		Use:   "ls",
 		Short: "list all environments owned by the active user",
 		Long:  "List all Coder environments owned by the active user.",
@@ -32,7 +47,7 @@ func envsCommand() *cobra.Command {
 			if err != nil {
 				return err
 			}
-			envs, err := getEnvs(cmd.Context(), client, user)
+			envs, err := getEnvs(cmd.Context(), client, *user)
 			if err != nil {
 				return err
 			}
@@ -60,16 +75,12 @@ func envsCommand() *cobra.Command {
 			return nil
 		},
 	}
-	lsCmd.Flags().StringVarP(&outputFmt, "output", "o", "human", "human | json")
-	cmd.AddCommand(lsCmd)
-	cmd.AddCommand(stopEnvCommand(&user))
+	cmd.Flags().StringVarP(&outputFmt, "output", "o", "human", "human | json")
 
-	cmd.AddCommand(watchBuildLogCommand())
-	cmd.AddCommand(rebuildEnvCommand())
 	return cmd
 }
 
-func stopEnvCommand(user *string) *cobra.Command {
+func stopEnvsCommand(user *string) *cobra.Command {
 	return &cobra.Command{
 		Use:   "stop [...environment_names]",
 		Short: "stop Coder environments by name",
@@ -117,3 +128,61 @@ coder envs --user charlie@coder.com ls -o json \
 		},
 	}
 }
+
+func rmEnvsCommand(user *string) *cobra.Command {
+	var force bool
+	cmd := &cobra.Command{
+		Use:   "rm [...environment_names]",
+		Short: "remove Coder environments by name",
+		Args:  cobra.MinimumNArgs(1),
+		RunE: func(cmd *cobra.Command, args []string) error {
+			ctx := cmd.Context()
+			client, err := newClient()
+			if err != nil {
+				return err
+			}
+
+			// only show one confirmation dialogue at a time
+			confirmLimiter := semaphore.NewWeighted(1)
+
+			var egroup errgroup.Group
+			for _, envName := range args {
+				envName := envName
+				egroup.Go(func() error {
+					env, err := findEnv(ctx, client, envName, *user)
+					if err != nil {
+						flog.Error("failed to find environment by name \"%s\": %v", envName, err)
+						return err
+					}
+					if !force {
+						confirm := promptui.Prompt{
+							Label:     fmt.Sprintf("Delete environment \"%s\"? (all data will be lost)", env.Name),
+							IsConfirm: true,
+						}
+						if err := confirmLimiter.Acquire(ctx, 1); err != nil {
+							return err
+						}
+
+						if _, err = confirm.Run(); err != nil {
+							confirmLimiter.Release(1)
+							return xerrors.Errorf("confirm deletion of environment \"%s\"", env.Name)
+						}
+						confirmLimiter.Release(1)
+					}
+					if err = client.DeleteEnvironment(cmd.Context(), env.ID); err != nil {
+						flog.Error("failed to delete environment \"%s\": %v", env.ID, err)
+						return xerrors.Errorf("delete environment: %w", err)
+					}
+					return nil
+				})
+			}
+
+			if err = egroup.Wait(); err != nil {
+				return xerrors.Errorf("some environment remove operations failed: %w", err)
+			}
+			return nil
+		},
+	}
+	cmd.Flags().BoolVarP(&force, "force", "f", false, "force remove the specified environments without prompting first")
+	return cmd
+}
