adding new tests and updated setupkube.go to work with gcp (CrunchyData#832)

Author: ValClarkson

testing/simple/setupkube.go

@@ -14,6 +14,7 @@ import (
 "k8s.io/client-go/kubernetes"
 "k8s.io/client-go/rest"
 "k8s.io/client-go/tools/clientcmd"
+_ "k8s.io/client-go/plugin/pkg/client/auth/gcp"
 )
 
 var (
@@ -22,7 +23,7 @@ var (
 testclustername = flag.String("clustername", "", "cluster name to test with")
 
 Namespace = "pgouser1"
-TestClusterName = "foo"
+TestClusterName = "foomatic"
 SLEEP_SECS = 10
 )
 

testing/simple/show_test.go

@@ -0,0 +1,142 @@
+package smoketest
+
+import (
+//meta_v1 "k8s.io/apimachinery/pkg/apis/meta/v1"
+"k8s.io/client-go/kubernetes"
+"os/exec"
+"strings"
+"testing"
+)
+
+func TestShowCluster(t *testing.T) {
+var clientset *kubernetes.Clientset
+var cluster string
+
+// t.Fatal("not implemented")
+t.Run("setup", func(t *testing.T) {
+t.Log("some setup code")
+clientset, _ = SetupKube()
+if clientset == nil {
+t.Error("clientset is nil")
+}
+})
+
+tests := []struct {
+name string
+args []string
+fixture string
+}{
+{"pgo show cluster", []string{"show", "cluster", TestClusterName}, ""},
+}
+
+t.Log("TestShowCluster starts")
+for _, tt := range tests {
+cmd := exec.Command("pgo", tt.args...)
+output, err := cmd.CombinedOutput()
+if err != nil {
+//t.Fatal(err)
+}
+
+actual := string(output)
+
+t.Logf("actual %s- ", actual)
+cluster = "cluster : " + TestClusterName
+found := strings.Contains(actual, cluster)
+if !found {
+t.Error("could not find cluster : " + TestClusterName + "in output")
+}
+
+}
+
+t.Run("teardown", func(t *testing.T) {
+t.Log("some teardown code")
+})
+}
+
+func TestShowNamespace(t *testing.T) {
+var clientset *kubernetes.Clientset
+
+// t.Fatal("not implemented")
+t.Run("setup", func(t *testing.T) {
+t.Log("some setup code")
+clientset, _ = SetupKube()
+if clientset == nil {
+t.Error("clientset is nil")
+}
+})
+
+tests := []struct {
+name string
+args []string
+fixture string
+}{
+{"pgo show namespace", []string{"show", "namespace"}, ""},
+}
+
+t.Log("TestShowNamespace starts")
+for _, tt := range tests {
+cmd := exec.Command("pgo", tt.args...)
+output, err := cmd.CombinedOutput()
+if err != nil {
+//t.Fatal(err)
+}
+
+actual := string(output)
+
+t.Logf("actual %s- ", actual)
+found := strings.Contains(actual, Namespace)
+if !found {
+t.Error("could not find " + Namespace + "namespace in output")
+}
+
+}
+
+t.Run("teardown", func(t *testing.T) {
+t.Log("some teardown code")
+})
+}
+
+
+func TestShowPvc(t *testing.T) {
+var clientset *kubernetes.Clientset
+
+// t.Fatal("not implemented")
+t.Run("setup", func(t *testing.T) {
+t.Log("some setup code")
+clientset, _ = SetupKube()
+if clientset == nil {
+t.Error("clientset is nil")
+}
+})
+
+tests := []struct {
+name string
+args []string
+fixture string
+}{
+{"pgo show pvc", []string{"show", "pvc", TestClusterName}, ""},
+}
+
+t.Log("TestShowPvc starts")
+for _, tt := range tests {
+cmd := exec.Command("pgo", tt.args...)
+output, err := cmd.CombinedOutput()
+if err != nil {
+//t.Fatal(err)
+}
+
+actual := string(output)
+
+t.Logf("actual %s- ", actual)
+found := strings.Contains(actual, "pgdata")
+if !found {
+t.Error("could not find pgdata in output")
+}
+
+}
+
+t.Run("teardown", func(t *testing.T) {
+t.Log("some teardown code")
+})
+}
+

testing/simple/user_test.go

@@ -0,0 +1,97 @@
+package smoketest
+
+import (
+//meta_v1 "k8s.io/apimachinery/pkg/apis/meta/v1"
+"k8s.io/client-go/kubernetes"
+"os/exec"
+"strings"
+"testing"
+)
+
+func TestCreateUser(t *testing.T) {
+var clientset *kubernetes.Clientset
+
+// t.Fatal("not implemented")
+t.Run("setup", func(t *testing.T) {
+t.Log("some setup code")
+clientset, _ = SetupKube()
+if clientset == nil {
+t.Error("clientset is nil")
+}
+})
+
+tests := []struct {
+name string
+args []string
+fixture string
+}{
+{"pgo create user", []string{"create", "user", "test2", "--managed","--selector=name=" + TestClusterName }, ""},
+}
+
+t.Log("TestCreateUser starts")
+for _, tt := range tests {
+cmd := exec.Command("pgo", tt.args...)
+output, err := cmd.CombinedOutput()
+if err != nil {
+//t.Fatal(err)
+}
+
+actual := string(output)
+
+t.Logf("actual %s- ", actual)
+found := strings.Contains(actual, "adding new user")
+if !found {
+t.Error("could not find adding new user in output")
+}
+
+}
+
+t.Run("teardown", func(t *testing.T) {
+t.Log("some teardown code")
+})
+}
+
+
+func TestDeleteUser(t *testing.T) {
+var clientset *kubernetes.Clientset
+
+// t.Fatal("not implemented")
+t.Run("setup", func(t *testing.T) {
+t.Log("some setup code")
+clientset, _ = SetupKube()
+if clientset == nil {
+t.Error("clientset is nil")
+}
+})
+
+tests := []struct {
+name string
+args []string
+fixture string
+}{
+{"pgo delete user", []string{"delete", "user", "test1", "--selector=name=" + TestClusterName }, ""},
+}
+
+t.Log("TestCreateUser starts")
+for _, tt := range tests {
+cmd := exec.Command("pgo", tt.args...)
+output, err := cmd.CombinedOutput()
+if err != nil {
+//t.Fatal(err)
+}
+
+actual := string(output)
+
+t.Logf("actual %s- ", actual)
+found := strings.Contains(actual, "delete")
+if !found {
+t.Error("could not find delete in output")
+}
+
+}
+
+t.Run("teardown", func(t *testing.T) {
+t.Log("some teardown code")
+})
+}
+//TODO: need to add pgo show user