Migrate Helm Chart to OSDK v1.3.0 (#551)

Migrate Helm Chart to OSDK v1.3.0
2026-10-18 23:40:31 +02:00 · 2021-04-29 13:50:06 +02:00
parent 223119b62d
commit c74606a2ee
34 changed files with 4338 additions and 488 deletions
@@ -0,0 +1,60 @@
+package helm
+
+import (
+	"fmt"
+	"os/exec"
+
+	"github.com/jenkinsci/kubernetes-operator/api/v1alpha2"
+	"github.com/jenkinsci/kubernetes-operator/test/e2e"
+
+	. "github.com/onsi/ginkgo"
+	. "github.com/onsi/gomega"
+	corev1 "k8s.io/api/core/v1"
+	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
+	// +kubebuilder:scaffold:imports
+)
+
+var _ = Describe("Jenkins controller", func() {
+	var (
+		namespace *corev1.Namespace
+	)
+
+	BeforeEach(func() {
+		namespace = e2e.CreateNamespace()
+	})
+	AfterEach(func() {
+		showLogsIfTestHasFailed(CurrentGinkgoTestDescription().Failed, namespace.Name)
+		e2e.DestroyNamespace(namespace)
+	})
+	Context("when deploying Helm Chart to cluster", func() {
+		It("creates Jenkins instance and configures it", func() {
+
+			jenkins := &v1alpha2.Jenkins{
+				TypeMeta: v1alpha2.JenkinsTypeMeta(),
+				ObjectMeta: metav1.ObjectMeta{
+					Name:      "jenkins",
+					Namespace: namespace.Name,
+				},
+			}
+
+			cmd := exec.Command("../../bin/helm", "upgrade", "jenkins", "../../chart/jenkins-operator", "--namespace", namespace.Name, "--debug",
+				"--set-string", fmt.Sprintf("jenkins.namespace=%s", namespace.Name),
+				"--set-string", fmt.Sprintf("operator.image=%s", *imageName), "--install")
+			output, err := cmd.CombinedOutput()
+			Expect(err).NotTo(HaveOccurred(), string(output))
+
+			e2e.WaitForJenkinsBaseConfigurationToComplete(jenkins)
+			e2e.WaitForJenkinsUserConfigurationToComplete(jenkins)
+
+			cmd = exec.Command("../../bin/helm", "upgrade", "jenkins", "../../chart/jenkins-operator", "--namespace", namespace.Name, "--debug",
+				"--set-string", fmt.Sprintf("jenkins.namespace=%s", namespace.Name),
+				"--set-string", fmt.Sprintf("operator.image=%s", *imageName), "--install")
+			output, err = cmd.CombinedOutput()
+
+			Expect(err).NotTo(HaveOccurred(), string(output))
+
+			e2e.WaitForJenkinsBaseConfigurationToComplete(jenkins)
+			e2e.WaitForJenkinsUserConfigurationToComplete(jenkins)
+		})
+	})
+})
@@ -0,0 +1,135 @@
+package helm
+
+import (
+	"bytes"
+	"context"
+	"fmt"
+	"io"
+	"sort"
+
+	"github.com/jenkinsci/kubernetes-operator/test/e2e"
+	"github.com/onsi/ginkgo"
+
+	corev1 "k8s.io/api/core/v1"
+	"k8s.io/api/events/v1beta1"
+	"k8s.io/apimachinery/pkg/labels"
+	"k8s.io/client-go/kubernetes"
+	"sigs.k8s.io/controller-runtime/pkg/client"
+)
+
+var (
+	podLogTailLimit       int64 = 15
+	kubernetesEventsLimit int64 = 15
+	// MUST match the labels in the deployment manifest: deploy/operator.yaml
+	operatorPodLabels = map[string]string{
+		"name": "jenkins-operator",
+	}
+)
+
+func getOperatorPod(namespace string) (*corev1.Pod, error) {
+	lo := &client.ListOptions{
+		LabelSelector: labels.SelectorFromSet(operatorPodLabels),
+		Namespace:     namespace,
+	}
+	pods := &corev1.PodList{}
+	err := e2e.K8sClient.List(context.TODO(), pods, lo)
+	if err != nil {
+		return nil, err
+	}
+	return &pods.Items[0], nil
+}
+
+func getOperatorLogs(namespace string) (string, error) {
+	pod, err := getOperatorPod(namespace)
+	if err != nil {
+		return "Operator pod doesn't exist", err
+	}
+	logOptions := corev1.PodLogOptions{TailLines: &podLogTailLimit}
+
+	// creates the clientset
+	clientset, err := kubernetes.NewForConfig(e2e.Cfg)
+	if err != nil {
+		return "", err
+	}
+	req := clientset.CoreV1().Pods(pod.Namespace).GetLogs(pod.Name, &logOptions)
+	podLogs, err := req.Stream(context.TODO())
+	if err != nil {
+		return "", err
+	}
+
+	defer func() {
+		if podLogs != nil {
+			_ = podLogs.Close()
+		}
+	}()
+
+	buf := new(bytes.Buffer)
+	_, err = io.Copy(buf, podLogs)
+	if err != nil {
+		return "", err
+	}
+
+	logs := buf.String()
+	return logs, nil
+}
+
+func printOperatorLogs(namespace string) {
+	_, _ = fmt.Fprintf(ginkgo.GinkgoWriter, "Operator logs in '%s' namespace:\n", namespace)
+	logs, err := getOperatorLogs(namespace)
+	if err != nil {
+		_, _ = fmt.Fprintf(ginkgo.GinkgoWriter, "Couldn't get the operator pod logs: %s", err)
+	} else {
+		_, _ = fmt.Fprintf(ginkgo.GinkgoWriter, "Last %d lines of log from operator:\n %s", podLogTailLimit, logs)
+	}
+}
+
+func getKubernetesEvents(namespace string) ([]v1beta1.Event, error) {
+	listOptions := &client.ListOptions{
+		Limit:     kubernetesEventsLimit,
+		Namespace: namespace,
+	}
+
+	events := &v1beta1.EventList{}
+	err := e2e.K8sClient.List(context.TODO(), events, listOptions)
+	if err != nil {
+		return nil, err
+	}
+	sort.SliceStable(events.Items, func(i, j int) bool {
+		return events.Items[i].CreationTimestamp.Unix() < events.Items[j].CreationTimestamp.Unix()
+	})
+
+	return events.Items, nil
+}
+
+func printKubernetesEvents(namespace string) {
+	_, _ = fmt.Fprintf(ginkgo.GinkgoWriter, "Kubernetes events in '%s' namespace:\n", namespace)
+	events, err := getKubernetesEvents(namespace)
+	if err != nil {
+		_, _ = fmt.Fprintf(ginkgo.GinkgoWriter, "Couldn't get kubernetes events: %s", err)
+	} else {
+		_, _ = fmt.Fprintf(ginkgo.GinkgoWriter, "Last %d events from kubernetes:\n", kubernetesEventsLimit)
+
+		for _, event := range events {
+			_, _ = fmt.Fprintf(ginkgo.GinkgoWriter, "%+v\n\n", event)
+		}
+	}
+}
+
+func printKubernetesPods(namespace string) {
+	_, _ = fmt.Fprintf(ginkgo.GinkgoWriter, "All pods in '%s' namespace:\n", namespace)
+
+	pod, err := getOperatorPod(namespace)
+	if err == nil {
+		_, _ = fmt.Fprintf(ginkgo.GinkgoWriter, "%+v\n\n", pod)
+	}
+}
+
+func showLogsIfTestHasFailed(failed bool, namespace string) {
+	if failed {
+		_, _ = fmt.Fprintf(ginkgo.GinkgoWriter, "Test failed. Bellow here you can check logs:")
+
+		printKubernetesEvents(namespace)
+		printKubernetesPods(namespace)
+		printOperatorLogs(namespace)
+	}
+}
@@ -0,0 +1,76 @@
+package helm
+
+import (
+	"flag"
+	"testing"
+
+	"github.com/jenkinsci/kubernetes-operator/api/v1alpha2"
+	"github.com/jenkinsci/kubernetes-operator/test/e2e"
+
+	. "github.com/onsi/ginkgo"
+	. "github.com/onsi/gomega"
+	"k8s.io/client-go/kubernetes/scheme"
+	ctrl "sigs.k8s.io/controller-runtime"
+	"sigs.k8s.io/controller-runtime/pkg/envtest"
+	"sigs.k8s.io/controller-runtime/pkg/envtest/printer"
+	logf "sigs.k8s.io/controller-runtime/pkg/log"
+	"sigs.k8s.io/controller-runtime/pkg/log/zap"
+	// +kubebuilder:scaffold:imports
+)
+
+var (
+	testEnv   *envtest.Environment
+	imageName *string
+)
+
+func init() {
+	imageName = flag.String("image-name", "", "Name of the locally built for testing Jenkins Operator Image.")
+}
+
+func TestHelm(t *testing.T) {
+	RegisterFailHandler(Fail)
+
+	RunSpecsWithDefaultAndCustomReporters(t,
+		"Controller Suite",
+		[]Reporter{printer.NewlineReporter{}})
+}
+
+var _ = BeforeSuite(func(done Done) {
+	logf.SetLogger(zap.New(zap.WriteTo(GinkgoWriter), zap.UseDevMode(false)))
+
+	By("bootstrapping test environment")
+	useExistingCluster := true
+	testEnv = &envtest.Environment{
+		UseExistingCluster: &useExistingCluster,
+	}
+
+	cfg, err := testEnv.Start()
+	Expect(err).NotTo(HaveOccurred())
+	Expect(cfg).NotTo(BeNil())
+
+	err = v1alpha2.AddToScheme(scheme.Scheme)
+	Expect(err).NotTo(HaveOccurred())
+
+	// +kubebuilder:scaffold:scheme
+
+	// setup manager
+	k8sManager, err := ctrl.NewManager(cfg, ctrl.Options{
+		Scheme: scheme.Scheme,
+	})
+	Expect(err).NotTo(HaveOccurred())
+
+	go func() {
+		err = k8sManager.Start(ctrl.SetupSignalHandler())
+		Expect(err).NotTo(HaveOccurred())
+	}()
+
+	e2e.K8sClient = k8sManager.GetClient()
+	Expect(e2e.K8sClient).NotTo(BeNil())
+	close(done)
+}, 60)
+
+var _ = AfterSuite(func() {
+	By("tearing down the test environment")
+	err := testEnv.Stop()
+	Expect(err).NotTo(HaveOccurred())
+})