Added option to delete all profiles

cmd/minikube/cmd/config/profile.go

@@ -17,15 +17,19 @@ limitations under the License.
 package config
 
 import (
-	"os"
-
+	"encoding/json"
 	"github.com/spf13/cobra"
 	"github.com/spf13/viper"
+	"io/ioutil"
+	mkConfig "k8s.io/minikube/pkg/minikube/config"
 	pkgConfig "k8s.io/minikube/pkg/minikube/config"
 	"k8s.io/minikube/pkg/minikube/console"
 	"k8s.io/minikube/pkg/minikube/constants"
 	"k8s.io/minikube/pkg/minikube/exit"
 	pkgutil "k8s.io/minikube/pkg/util"
+	"os"
+	"path/filepath"
+	"reflect"
 )
 
 // ProfileCmd represents the profile command
@@ -71,3 +75,68 @@ var ProfileCmd = &cobra.Command{
 		console.Success("minikube profile was successfully set to %s", profile)
 	},
 }
+
+func GetAllProfiles() []string {
+	miniPath := constants.GetMinipath()
+	profilesPath := filepath.Join(miniPath, "profiles")
+	fileInfos, err := ioutil.ReadDir(profilesPath)
+	if err != nil {
+		console.ErrLn("Unable to list in dir: %s \n Error: %v", profilesPath, err)
+	}
+
+	var profiles []string
+	for _, fileInfo := range fileInfos {
+		if fileInfo.IsDir() {
+			profilePath := filepath.Join(profilesPath, fileInfo.Name())
+			if isValidProfile(profilePath) {
+				profiles = append(profiles, fileInfo.Name())
+			}
+		}
+	}
+	return profiles
+}
+
+func isValidProfile(profilePath string) bool {
+	fileInfos, err := ioutil.ReadDir(profilePath)
+	if err != nil {
+		console.ErrLn("Unable to list in dir: %s \n Error: %v", profilePath, err)
+	}
+
+	hasConfigJSON := false
+	for _, fileInfo := range fileInfos {
+		if fileInfo.Name() == "config.json" {
+			hasConfigJSON = true
+		}
+	}
+
+	if !hasConfigJSON {
+		return false
+	}
+
+	// TODO: Use constants?
+	profileConfigPath := filepath.Join(profilePath, "config.json")
+	bytes, err := ioutil.ReadFile(profileConfigPath)
+	if err != nil {
+		console.ErrLn("Unable to read file: %s \n Error: %v", profileConfigPath, err)
+	}
+
+	var configObject mkConfig.Config
+	errUnmarshal := json.Unmarshal(bytes, &configObject)
+
+	if errUnmarshal != nil {
+		console.ErrLn("Could not unmarshal config json to config object: %s \n Error: %v", profileConfigPath, err)
+	}
+	return IsProfileConfigValid(configObject)
+}
+
+func IsProfileConfigValid(configObject mkConfig.Config) bool {
+	machineConfig := configObject.MachineConfig
+	kubernetesConfig := configObject.KubernetesConfig
+	if reflect.DeepEqual(machineConfig, mkConfig.MachineConfig{}) || reflect.DeepEqual(kubernetesConfig, mkConfig.KubernetesConfig{}) {
+		return false
+	}
+
+	//TODO: Validate MachineConfig and KubernetesConfig?
+
+	return true
+}

cmd/minikube/cmd/delete.go

@@ -35,6 +35,8 @@ import (
 	pkgutil "k8s.io/minikube/pkg/util"
 )
 
+var deleteAll bool
+
 // deleteCmd represents the delete command
 var deleteCmd = &cobra.Command{
 	Use:   "delete",
@@ -46,10 +48,27 @@ associated files.`,
 
 // runDelete handles the executes the flow of "minikube delete"
 func runDelete(cmd *cobra.Command, args []string) {
-	if len(args) > 0 {
-		exit.Usage("usage: minikube delete")
+	profileFlag, _ := cmd.Flags().GetString("profile")
+	deleteAllFlag, _ := cmd.Flags().GetBool("all")
+
+	if profileFlag != constants.DefaultMachineName && deleteAllFlag {
+		exit.Usage("usage: minikube delete --all")
+	}
+
+	if deleteAllFlag {
+		profiles := cmdcfg.GetAllProfiles()
+		deleteAllProfiles(profiles)
+	} else {
+		if len(args) > 0 {
+			exit.Usage("usage: minikube delete")
+		}
+
+		profileName := viper.GetString(pkg_config.MachineProfile)
+		deleteProfile(profileName)
 	}
-	profile := viper.GetString(pkg_config.MachineProfile)
+}
+
+func deleteProfile(profileName string) {
 	api, err := machine.NewAPIClient()
 	if err != nil {
 		exit.WithError("Error getting client", err)
@@ -69,7 +88,7 @@ func runDelete(cmd *cobra.Command, args []string) {
 	if err = cluster.DeleteHost(api); err != nil {
 		switch err := errors.Cause(err).(type) {
 		case mcnerror.ErrHostDoesNotExist:
-			console.OutStyle(console.Meh, "%q cluster does not exist", profile)
+			console.OutStyle(console.Meh, "%q cluster does not exist", profileName)
 		default:
 			exit.WithError("Failed to delete cluster", err)
 		}
@@ -81,19 +100,28 @@ func runDelete(cmd *cobra.Command, args []string) {
 
 	if err := os.RemoveAll(constants.GetProfilePath(viper.GetString(pkg_config.MachineProfile))); err != nil {
 		if os.IsNotExist(err) {
-			console.OutStyle(console.Meh, "%q profile does not exist", profile)
+			console.OutStyle(console.Meh, "%q profile does not exist", profileName)
 			os.Exit(0)
 		}
 		exit.WithError("Failed to remove profile", err)
 	}
-	console.OutStyle(console.Crushed, "The %q cluster has been deleted.", profile)
+	console.OutStyle(console.Crushed, "The %q cluster has been deleted.", profileName)
 
 	machineName := pkg_config.GetMachineName()
 	if err := pkgutil.DeleteKubeConfigContext(constants.KubeconfigPath, machineName); err != nil {
 		exit.WithError("update config", err)
 	}
 }
 
+func deleteAllProfiles(profiles []string) {
+	for _, profile := range profiles {
+		// TODO: Refactor: viper.Set seems to be in the wrong place
+		viper.Set(pkg_config.MachineProfile, profile)
+		deleteProfile(profile)
+	}
+	os.Exit(0)
+}
+
 func uninstallKubernetes(api libmachine.API, kc pkg_config.KubernetesConfig, bsName string) {
 	console.OutStyle(console.Resetting, "Uninstalling Kubernetes %s using %s ...", kc.KubernetesVersion, bsName)
 	clusterBootstrapper, err := GetClusterBootstrapper(api, bsName)
@@ -105,5 +133,6 @@ func uninstallKubernetes(api libmachine.API, kc pkg_config.KubernetesConfig, bsN
 }
 
 func init() {
+	deleteCmd.Flags().BoolVar(&deleteAll, "all", false, "Set flag to delete all profiles")
 	RootCmd.AddCommand(deleteCmd)
 }