delete_devpod.go

package deletecmd

import (
	"fmt"
	"strings"

	"github.com/jenkins-x/jx/v2/pkg/cmd/helper"
	"github.com/jenkins-x/jx/v2/pkg/kube/naming"
	"github.com/pkg/errors"

	"github.com/jenkins-x/jx-logging/pkg/log"
	"github.com/jenkins-x/jx/v2/pkg/cmd/opts"
	"github.com/jenkins-x/jx/v2/pkg/cmd/templates"
	"github.com/spf13/cobra"

	"github.com/jenkins-x/jx/v2/pkg/kube"
	"github.com/jenkins-x/jx/v2/pkg/util"
	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
)

var (
	deleteDevPodLong = templates.LongDesc(`
		Deletes one or more DevPods

		For more documentation see: [https://jenkins-x.io/developing/devpods/](https://jenkins-x.io/developing/devpods/)

`)

	deleteDevPodExample = templates.Examples(`
		# deletes a DevPod by picking one from the list and confirming to it
		jx delete devpod

		# delete a specific DevPod
		jx delete devpod myuser-maven2
	`)
)

// DeleteDevPodOptions are the flags for delete commands
type DeleteDevPodOptions struct {
	*opts.CommonOptions
	opts.CommonDevPodOptions
}

// NewCmdDeleteDevPod creates a command object for the generic "get" action, which
// retrieves one or more resources from a server.
func NewCmdDeleteDevPod(commonOpts *opts.CommonOptions) *cobra.Command {
	options := &DeleteDevPodOptions{
		CommonOptions: commonOpts,
	}

	cmd := &cobra.Command{
		Use:     "devpod",
		Short:   "Deletes one or more DevPods",
		Long:    deleteDevPodLong,
		Example: deleteDevPodExample,
		Aliases: []string{"buildpod", "buildpods", "devpods"},
		Run: func(cmd *cobra.Command, args []string) {
			options.Cmd = cmd
			options.Args = args
			err := options.Run()
			helper.CheckErr(err)
		},
	}

	options.AddCommonDevPodFlags(cmd)

	return cmd
}

// Run implements this command
func (o *DeleteDevPodOptions) Run() error {
	devPods := o.Args

	client, curNs, err := o.KubeClientAndNamespace()
	if err != nil {
		return errors.Wrap(err, "getting the kubernetes client")
	}
	ns, _, err := kube.GetDevNamespace(client, curNs)
	if err != nil {
		return errors.Wrap(err, "getting the dev namespace")
	}
	userName, err := o.GetUsername(o.CommonDevPodOptions.Username)
	if err != nil {
		return errors.Wrap(err, "getting the current user")
	}
	name := naming.ToValidName(userName)
	names, err := kube.GetPodNames(client, ns, name)
	if err != nil {
		return errors.Wrap(err, "getting the pod names")
	}

	info := util.ColorInfo
	if len(names) == 0 {
		return fmt.Errorf("There are no DevPods for user %s in namespace %s. You can create one via: %s\n", info(userName), info(ns), info("jx create devpod"))
	}

	if len(devPods) == 0 {
		devPods, err = util.PickNames(names, "Pick DevPod:", "", o.GetIOFileHandles())
		if err != nil {
			return errors.Wrap(err, "picking the DevPod names")
		}
	}

	deletePods := strings.Join(devPods, ", ")

	if !o.BatchMode {
		if answer, err := util.Confirm("You are about to delete the DevPods: "+deletePods, false, "The list of DevPods names to be deleted", o.GetIOFileHandles()); !answer {
			return err
		}
	}
	for _, name := range devPods {
		if util.StringArrayIndex(names, name) < 0 {
			return util.InvalidOption(opts.OptionLabel, name, names)
		}
		log.Logger().Debugf("About to delete Devpod %s", name)
		err = client.CoreV1().Pods(ns).Delete(name, &metav1.DeleteOptions{})
		if err != nil {
			return errors.Wrapf(err, "deleting the devpod %q", name)
		}
	}
	log.Logger().Infof("Deleted DevPods %s", util.ColorInfo(deletePods))
	return nil
}