remove local kubeconfig when changing project or cluster

api/client/k8s.go

@@ -3,8 +3,12 @@ package client
 import (
 	"context"
 	"fmt"
+	"io"
+	"os"
 
+	"github.com/fatih/color"
 	"github.com/porter-dev/porter/api/types"
+
 	v1 "k8s.io/api/batch/v1"
 )
 
@@ -55,9 +59,34 @@ func (c *Client) GetKubeconfig(
 	ctx context.Context,
 	projectID uint,
 	clusterID uint,
+	localKubeconfig string,
 ) (*types.GetTemporaryKubeconfigResponse, error) {
 	resp := &types.GetTemporaryKubeconfigResponse{}
 
+	if localKubeconfig != "" {
+		color.New(color.FgBlue).Printf("using local kubeconfig: %s\n", localKubeconfig)
+
+		if _, err := os.Stat(localKubeconfig); !os.IsNotExist(err) {
+			file, err := os.Open(localKubeconfig)
+
+			if err != nil {
+				return nil, err
+			}
+
+			data, err := io.ReadAll(file)
+
+			if err != nil {
+				return nil, err
+			}
+
+			resp.Kubeconfig = append(resp.Kubeconfig, data...)
+
+			return resp, nil
+		}
+	}
+
+	color.New(color.FgBlue).Println("using remote kubeconfig")
+
 	err := c.getRequest(
 		fmt.Sprintf(
 			"/projects/%d/clusters/%d/kubeconfig",

cli/cmd/config/config.go

@@ -212,6 +212,12 @@ func (c *CLIConfig) SetHost(host string) error {
 }
 
 func (c *CLIConfig) SetProject(projectID uint) error {
+	if config.Kubeconfig != "" || viper.IsSet("kubeconfig") {
+		viper.Set("kubeconfig", "")
+		color.New(color.FgBlue).Println("Removing local kubeconfig")
+		config.Kubeconfig = ""
+	}
+
 	viper.Set("project", projectID)
 	color.New(color.FgGreen).Printf("Set the current project as %d\n", projectID)
 	err := viper.WriteConfig()
@@ -226,6 +232,12 @@ func (c *CLIConfig) SetProject(projectID uint) error {
 }
 
 func (c *CLIConfig) SetCluster(clusterID uint) error {
+	if config.Kubeconfig != "" || viper.IsSet("kubeconfig") {
+		viper.Set("kubeconfig", "")
+		color.New(color.FgBlue).Println("Removing local kubeconfig")
+		config.Kubeconfig = ""
+	}
+
 	viper.Set("cluster", clusterID)
 	color.New(color.FgGreen).Printf("Set the current cluster as %d\n", clusterID)
 	err := viper.WriteConfig()

cli/cmd/portforward.go

@@ -3,7 +3,6 @@ package cmd
 import (
 	"context"
 	"fmt"
-	"io"
 	"net/http"
 	"net/url"
 	"os"
@@ -146,30 +145,14 @@ func portForward(user *types.GetAuthenticatedUserResponse, client *api.Client, a
 		pod = pods[0]
 	}
 
-	var kubeBytes []byte
+	kubeResp, err := client.GetKubeconfig(context.TODO(), cliConf.Project, cliConf.Cluster, cliConf.Kubeconfig)
 
-	if cliConf.Kubeconfig == "" {
-		kubeResp, err := client.GetKubeconfig(context.TODO(), cliConf.Project, cliConf.Cluster)
-
-		if err != nil {
-			return err
-		}
-
-		kubeBytes = kubeResp.Kubeconfig
-	} else {
-		file, err := os.Open(cliConf.Kubeconfig)
-
-		if err != nil {
-			return err
-		}
-
-		kubeBytes, err = io.ReadAll(file)
-
-		if err != nil {
-			return err
-		}
+	if err != nil {
+		return err
 	}
 
+	kubeBytes := kubeResp.Kubeconfig
+
 	cmdConf, err := clientcmd.NewClientConfigFromBytes(kubeBytes)
 
 	if err != nil {

cli/cmd/run.go

@@ -264,30 +264,14 @@ func (p *PorterRunSharedConfig) setSharedConfig() error {
 	pID := cliConf.Project
 	cID := cliConf.Cluster
 
-	var kubeBytes []byte
+	kubeResp, err := p.Client.GetKubeconfig(context.TODO(), pID, cID, cliConf.Kubeconfig)
 
-	if cliConf.Kubeconfig == "" {
-		kubeResp, err := p.Client.GetKubeconfig(context.TODO(), pID, cID)
-
-		if err != nil {
-			return err
-		}
-
-		kubeBytes = kubeResp.Kubeconfig
-	} else {
-		file, err := os.Open(cliConf.Kubeconfig)
-
-		if err != nil {
-			return err
-		}
-
-		kubeBytes, err = io.ReadAll(file)
-
-		if err != nil {
-			return err
-		}
+	if err != nil {
+		return err
 	}
 
+	kubeBytes := kubeResp.Kubeconfig
+
 	cmdConf, err := clientcmd.NewClientConfigFromBytes(kubeBytes)
 
 	if err != nil {