From 38dc2bd6d6c11987995fe22516b5cdd4fd75a968 Mon Sep 17 00:00:00 2001 From: Fabio Yeon Date: Sat, 17 Oct 2015 22:34:43 -0700 Subject: [PATCH] Revert "e2e: kubectl HTTP fix for #15713" --- test/e2e/kubectl.go | 54 +++++++++++++++------------------------------ 1 file changed, 18 insertions(+), 36 deletions(-) diff --git a/test/e2e/kubectl.go b/test/e2e/kubectl.go index 370a77e16a..677ca78de8 100644 --- a/test/e2e/kubectl.go +++ b/test/e2e/kubectl.go @@ -26,7 +26,6 @@ import ( "mime/multipart" "net" "net/http" - "net/url" "os" "os/exec" "path" @@ -198,7 +197,8 @@ var _ = Describe("Kubectl client", func() { } }) - It("should support exec through an HTTP proxy", func() { + // FIXME(ncdc) remove Skipped once we sort out the kubectl build issues in GCE + It("[Skipped] should support exec through an HTTP proxy", func() { // Note: We are skipping local since we want to verify an apiserver with HTTPS. // At this time local only supports plain HTTP. SkipIfProviderIs("local") @@ -206,51 +206,33 @@ var _ = Describe("Kubectl client", func() { if testContext.Host == "" { Failf("--host variable must be set to the full URI to the api server on e2e run.") } - - // Make sure the apiServer is set to what kubectl requires apiServer := testContext.Host - apiServerUrl, err := url.Parse(apiServer) - if err != nil { - Failf("Unable to parse URL %s. Error=Ts", apiServer, err) + // If there is no api in URL try to add it + if !strings.Contains(apiServer, ":443/api") { + apiServer = apiServer + ":443/api" } - apiServerUrl.Scheme = "https" - apiServerUrl.Path = "/api" - if !strings.Contains(apiServer, ":443") { - apiServerUrl.Host = apiServerUrl.Host + ":443" - } - apiServer = apiServerUrl.String() // Get the kube/config + // TODO: Can it be RepoRoot with jenkins e2e? testWorkspace := os.Getenv("WORKSPACE") if testWorkspace == "" { // Not running in jenkins, assume RepoRoot - testWorkspace = testContext.RepoRoot + testWorkspace = testContext.RepoRoot // os.Getenv("HOME") } // Build the static kubectl - By("Finding a static kubectl for upload") - testStaticKubectlPath := path.Join(testWorkspace, "platforms/linux/386/kubectl") - _, err = os.Stat(testStaticKubectlPath) - if err != nil { - Logf("No kubectl in %s. Attempting a local build...", testStaticKubectlPath) - // Fall back to trying to build a local static kubectl - kubectlContainerPath := path.Join(testWorkspace, "/examples/kubectl-container/") - if _, err := os.Stat(path.Join(testWorkspace, "hack/build-go.sh")); err != nil { - Failf("Can't build static kubectl due to missing hack/build-go.sh. Error=%s", err) - } - By("Building a static kubectl for upload") - staticKubectlBuild := exec.Command("make", "-C", kubectlContainerPath) - if out, err := staticKubectlBuild.Output(); err != nil { - Failf("Unable to create static kubectl. Error=%s, Output=%q", err, out) - } - // Verify the static kubectl path - testStaticKubectlPath = path.Join(kubectlContainerPath, "kubectl") - _, err := os.Stat(testStaticKubectlPath) - if err != nil { - Failf("static kubectl path could not be found in %s. Error=%s", testStaticKubectlPath, err) - } + By("Building a static kubectl for upload") + kubectlContainerPath := path.Join(testWorkspace, "/examples/kubectl-container/") + staticKubectlBuild := exec.Command("make", "-C", kubectlContainerPath) + if out, err := staticKubectlBuild.Output(); err != nil { + Failf("Unable to create static kubectl. Error=%s, Output=%s", err, out) + } + // Verify the static kubectl path + testStaticKubectlPath := path.Join(kubectlContainerPath, "kubectl") + _, err := os.Stat(testStaticKubectlPath) + if err != nil { + Failf("static kubectl path could not be accessed. Error=%s", err) } - By(fmt.Sprintf("Using the kubectl in %s", testStaticKubectlPath)) // Verify the kubeconfig path kubeConfigFilePath := testContext.KubeConfig