run TSB test as part of the normal conformance bucket

Author: deads2k

test/testdata/templateservicebroker/templateservicebroker-template.yaml renamed to examples/templateservicebroker/templateservicebroker-template.yaml

@@ -32,7 +32,6 @@ objects:
         containers:
         - name: c
           image: ${IMAGE}
-          imagePullPolicy: Never
           command:
           - "/usr/bin/openshift"
           - "start"

hack/update-generated-bindata.sh

@@ -32,8 +32,8 @@ pushd "${OS_ROOT}" > /dev/null
     examples/heapster/... \
     examples/prometheus/... \
     examples/service-catalog/... \
-    pkg/image/admission/imagepolicy/api/v1/... \
-    test/testdata/templateservicebroker/...
+    examples/templateservicebroker/... \
+    pkg/image/admission/imagepolicy/api/v1/...
 
 "$(os::util::find::gopath_binary go-bindata)" \
     -nocompress \
@@ -51,7 +51,8 @@ pushd "${OS_ROOT}" > /dev/null
     examples/sample-app \
     examples/prometheus/... \
     examples/hello-openshift \
-    examples/jenkins/...
+    examples/jenkins/... \
+    examples/templateservicebroker/...
 
 popd > /dev/null
 

pkg/oc/bootstrap/bindata.go

@@ -15,6 +15,8 @@ import (
 )
 
 type Client interface {
+	Client() *http.Client
+
 	Catalog(ctx context.Context) (*api.CatalogResponse, error)
 	Provision(ctx context.Context, instanceID string, preq *api.ProvisionRequest) (*api.ProvisionResponse, error)
 	Deprovision(ctx context.Context, instanceID string) error
@@ -44,6 +46,10 @@ func newServerError(statusCode int, description string) error {
 	return &ServerError{StatusCode: statusCode, Description: description}
 }
 
+func (c *client) Client() *http.Client {
+	return c.cli
+}
+
 func (c *client) Catalog(ctx context.Context) (*api.CatalogResponse, error) {
 	req, err := http.NewRequest(http.MethodGet, c.root+"/v2/catalog", nil)
 	if err != nil {

pkg/openservicebroker/client/client.go

@@ -1,16 +1,37 @@
 package templates
 
 import (
+	"crypto/tls"
+	"encoding/json"
 	"fmt"
+	"io/ioutil"
+	"net/http"
+	"os/exec"
+	"time"
 
 	g "github.com/onsi/ginkgo"
 	o "github.com/onsi/gomega"
 
+	kerrors "k8s.io/apimachinery/pkg/api/errors"
+	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
+	"k8s.io/apimachinery/pkg/util/wait"
+	"k8s.io/client-go/pkg/apis/extensions"
+	kapi "k8s.io/kubernetes/pkg/api"
+	kapiv1 "k8s.io/kubernetes/pkg/api/v1"
+	kexternalclientset "k8s.io/kubernetes/pkg/client/clientset_generated/clientset"
+	e2e "k8s.io/kubernetes/test/e2e/framework"
+	intframework "k8s.io/kubernetes/test/integration/framework"
+
 	authorizationapi "github.com/openshift/origin/pkg/authorization/apis/authorization"
+	osbclient "github.com/openshift/origin/pkg/openservicebroker/client"
+	templateapi "github.com/openshift/origin/pkg/template/apis/template"
 	userapi "github.com/openshift/origin/pkg/user/apis/user"
 	exutil "github.com/openshift/origin/test/extended/util"
-	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
-	kapi "k8s.io/kubernetes/pkg/api"
+)
+
+const (
+	tsbNS   = "openshift-template-service-broker"
+	tsbHost = "apiserver." + tsbNS + ".svc"
 )
 
 func createUser(cli *exutil.CLI, name, role string) *userapi.User {
@@ -58,3 +79,96 @@ func setUser(cli *exutil.CLI, user *userapi.User) {
 		cli.ChangeUser(user.Name)
 	}
 }
+
+func EnsureTSB(tsbOC *exutil.CLI) (osbclient.Client, *exec.Cmd) {
+	exists := true
+	if _, err := tsbOC.AdminKubeClient().Extensions().DaemonSets(tsbNS).Get("apiserver", metav1.GetOptions{}); err != nil {
+		if !kerrors.IsNotFound(err) {
+			o.Expect(err).NotTo(o.HaveOccurred())
+		}
+		exists = false
+	}
+
+	if !exists {
+		e2e.Logf("Installing TSB onto the cluster for testing")
+		_, _, err := tsbOC.AsAdmin().WithoutNamespace().Run("create", "namespace").Args(tsbNS).Outputs()
+		o.Expect(err).NotTo(o.HaveOccurred())
+		configPath := exutil.FixturePath("..", "..", "examples", "templateservicebroker", "templateservicebroker-template.yaml")
+		stdout, _, err := tsbOC.WithoutNamespace().Run("process").Args("-f", configPath).Outputs()
+		o.Expect(err).NotTo(o.HaveOccurred())
+		err = tsbOC.WithoutNamespace().AsAdmin().Run("create").Args("-f", "-").InputString(stdout).Execute()
+		// this is weird, but we have to ignore this error in case some of this already exists (race between tests and the like)
+		//o.Expect(err).NotTo(o.HaveOccurred())
+		err = WaitForDaemonSetStatus(tsbOC.AdminKubeClient(), &extensions.DaemonSet{ObjectMeta: metav1.ObjectMeta{Name: "apiserver", Namespace: tsbNS}})
+		o.Expect(err).NotTo(o.HaveOccurred())
+	}
+
+	// we're trying to test the TSB, not the service.  We're outside all the normal networks.  Run a portforward to a particular
+	// pod and test that
+	pods, err := tsbOC.AdminKubeClient().Core().Pods(tsbNS).List(metav1.ListOptions{})
+	o.Expect(err).NotTo(o.HaveOccurred())
+	var pod *kapiv1.Pod
+	for i := range pods.Items {
+		currPod := pods.Items[i]
+		for _, cond := range currPod.Status.Conditions {
+			if cond.Type == kapiv1.PodReady && cond.Status == kapiv1.ConditionTrue {
+				pod = &currPod
+				break
+			} else {
+				out, _ := json.Marshal(currPod.Status)
+				e2e.Logf("%v %v", currPod.Name, string(out))
+			}
+		}
+	}
+	if pod == nil {
+		e2e.Failf("no ready pod found")
+	}
+	port, err := intframework.FindFreeLocalPort()
+	o.Expect(err).NotTo(o.HaveOccurred())
+	portForwardCmd, _, _, err := tsbOC.AsAdmin().WithoutNamespace().Run("port-forward").Args("-n="+tsbNS, pod.Name, fmt.Sprintf("%d:8443", port)).Background()
+	o.Expect(err).NotTo(o.HaveOccurred())
+
+	svc, err := tsbOC.AdminKubeClient().Core().Services(tsbNS).Get("apiserver", metav1.GetOptions{})
+	o.Expect(err).NotTo(o.HaveOccurred())
+	tsbclient := osbclient.NewClient(&http.Client{Transport: &http.Transport{TLSClientConfig: &tls.Config{InsecureSkipVerify: true}}}, fmt.Sprintf("https://localhost:%d%s", port, templateapi.ServiceBrokerRoot))
+
+	// wait to get back healthy from the tsb
+	healthResponse := ""
+	err = wait.Poll(e2e.Poll, 2*time.Minute, func() (bool, error) {
+		resp, err := tsbclient.Client().Get("https://" + svc.Spec.ClusterIP + "/healthz")
+		if err != nil {
+			return false, err
+		}
+		defer resp.Body.Close()
+		content, _ := ioutil.ReadAll(resp.Body)
+		healthResponse = string(content)
+		if resp.StatusCode == http.StatusOK {
+			return true, nil
+		}
+		return false, nil
+	})
+	if err != nil {
+		o.Expect(fmt.Errorf("error waiting for the TSB to be healthy: %v: %v", healthResponse, err)).NotTo(o.HaveOccurred())
+	}
+
+	return tsbclient, portForwardCmd
+}
+
+// Waits for the daemonset to have at least one ready pod
+func WaitForDaemonSetStatus(c kexternalclientset.Interface, d *extensions.DaemonSet) error {
+	err := wait.Poll(e2e.Poll, 5*time.Minute, func() (bool, error) {
+		var err error
+		ds, err := c.Extensions().DaemonSets(d.Namespace).Get(d.Name, metav1.GetOptions{})
+		if err != nil {
+			return false, err
+		}
+		if ds.Status.NumberReady > 0 {
+			return true, nil
+		}
+		return false, nil
+	})
+	if err != nil {
+		return fmt.Errorf("error waiting for ds %q status to match expectation: %v", d.Name, err)
+	}
+	return nil
+}