Handle kubeconfig correct for proxy mode

pkg/shalm/k8s.go

@@ -4,6 +4,7 @@ import (
 	"bytes"
 	"fmt"
 	"io"
+	"io/ioutil"
 	"os"
 	"os/exec"
 	"strings"
@@ -109,9 +110,17 @@ func (k *k8sImpl) IsNotExist(err error) bool {
 	return strings.Contains(err.Error(), "NotFound")
 }
 
-// IsNotExist -
+// KubeConfigContent -
 func (k *k8sImpl) KubeConfigContent() *string {
-	return k.kubeconfig
+	if k.kubeconfig == nil {
+		return nil
+	}
+	data, err := ioutil.ReadFile(*k.kubeconfig)
+	if err != nil {
+		return nil
+	}
+	content := string(data)
+	return &content
 }
 
 func run(cmd *exec.Cmd) error {

pkg/shalm/k8s_test.go

@@ -4,6 +4,7 @@ import (
 	"bytes"
 	"io"
 
+	. "github.com/kramerul/shalm/pkg/shalm/test"
 	. "github.com/onsi/ginkgo"
 	. "github.com/onsi/gomega"
 )
@@ -37,6 +38,17 @@ var _ = Describe("k8s", func() {
 		Expect(err).NotTo(HaveOccurred())
 		Expect(writer.String()).To(Equal("get kind name -o json\n"))
 	})
+	It("KubeConfigContent works", func() {
+		dir := NewTestDir()
+		defer dir.Remove()
+		dir.MkdirAll("chart2/templates", 0755)
+		dir.WriteFile("kubeconfig", []byte("hello"), 0644)
+		kubeconfig := dir.Join("kubeconfig")
+		k8s := k8sImpl{kubeconfig: &kubeconfig}
+		content := k8s.KubeConfigContent()
+		Expect(content).NotTo(BeNil())
+		Expect(*content).To(Equal("hello"))
+	})
 	// It("watch works", func() {
 	// 	reader, err := k8s.Watch("kind", "name", &K8sOptions{})
 	// 	Expect(err).NotTo(HaveOccurred())