it test changes from michaelschiff:rules_gitops:symlink-config-stable

Author: apesternikov

examples/WORKSPACE

@@ -23,6 +23,14 @@ load("@com_adobe_rules_gitops//gitops:repositories.bzl", "rules_gitops_repositor
 
 rules_gitops_repositories()
 
+load("@com_adobe_rules_gitops//skylib:k8s.bzl", "kubeconfig")
+
+kubeconfig(
+    name = "k8s_test",
+    cluster = "kind-kind",
+    symlink = True,
+)
+
 #
 # Repository dependencies
 #

examples/helloworld/BUILD

@@ -12,7 +12,7 @@ licenses(["notice"])  # Apache 2.0
 
 load("@io_bazel_rules_docker//go:image.bzl", "go_image")
 load("@io_bazel_rules_go//go:def.bzl", "go_binary", "go_library", "go_test")
-load("@com_adobe_rules_gitops//gitops:defs.bzl", "k8s_deploy")
+load("@com_adobe_rules_gitops//gitops:defs.bzl", "k8s_deploy", "k8s_test_setup")
 
 go_library(
     name = "go_default_library",
@@ -138,3 +138,27 @@ sh_test(
         "@bazel_tools//tools/bash/runfiles",
     ],
 )
+
+k8s_test_setup(
+    name = "service_it.setup",
+    kubeconfig = "@k8s_test//:kubeconfig",
+    objects = [
+        ":mynamespace",
+    ],
+)
+
+go_test(
+    name = "helloworld_integration_test",
+    srcs = ["helloworld_integration_test.go"],
+    args = [
+        "-setup",
+        "$(location :service_it.setup)",
+    ],
+    data = [
+        ":service_it.setup",
+    ],
+    rundir = ".",
+    deps = [
+        "@com_adobe_rules_gitops//testing/it_sidecar/client:go_default_library",
+    ],
+)

examples/helloworld/helloworld_integration_test.go

@@ -0,0 +1,34 @@
+package main
+
+import (
+	"fmt"
+	"net/http"
+	"io/ioutil"
+	"strings"
+	"testing"
+
+	"github.com/adobe/rules_gitops/testing/it_sidecar/client"
+)
+
+var setup client.K8STestSetup
+
+func TestMain(m *testing.M) {
+	setup = client.K8STestSetup{PortForwardServices: map[string]int{"helloworld": 8080}}
+	setup.TestMain(m)
+}
+
+func TestSuccessfulReceival(t *testing.T) {
+	localPort := setup.GetServiceLocalPort("helloworld")
+	fmt.Printf("helloworld server is available at localport %d\n", localPort)
+	resp, err := http.Get(fmt.Sprintf("http://localhost:%d", localPort))
+	if err != nil {
+		t.Fatalf("request error %s", err)
+	}
+	if resp.StatusCode != 200 {
+		t.Fatalf("Unexpected status code %d, expectted 200", resp.StatusCode)
+	}
+	body, _ := ioutil.ReadAll(resp.Body)
+	if !strings.Contains(string(body), "Hello World") {
+		t.Error("Unexpected content returned:", string(body))
+	}
+}