mirror of
https://github.com/netbirdio/kubernetes-operator.git
synced 2026-05-22 17:11:40 -07:00
110 lines
3.9 KiB
Go
110 lines
3.9 KiB
Go
/*
|
|
Copyright 2025.
|
|
|
|
Licensed under the Apache License, Version 2.0 (the "License");
|
|
you may not use this file except in compliance with the License.
|
|
You may obtain a copy of the License at
|
|
|
|
http://www.apache.org/licenses/LICENSE-2.0
|
|
|
|
Unless required by applicable law or agreed to in writing, software
|
|
distributed under the License is distributed on an "AS IS" BASIS,
|
|
WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
|
|
See the License for the specific language governing permissions and
|
|
limitations under the License.
|
|
*/
|
|
|
|
package e2e
|
|
|
|
import (
|
|
"context"
|
|
"fmt"
|
|
"os"
|
|
"os/exec"
|
|
"path"
|
|
"testing"
|
|
|
|
netbird "github.com/netbirdio/netbird/management/client/rest"
|
|
. "github.com/onsi/ginkgo/v2"
|
|
. "github.com/onsi/gomega"
|
|
|
|
"github.com/netbirdio/kubernetes-operator/test/utils"
|
|
)
|
|
|
|
const apiToken = "nbp_apTmlmUXHSC4PKmHwtIZNaGr8eqcVI2gMURp"
|
|
|
|
var (
|
|
// Optional Environment Variables:
|
|
// - CERT_MANAGER_INSTALL_SKIP=true: Skips CertManager installation during test setup.
|
|
// This variable is useful if CertManager is already installed, avoiding
|
|
// re-installation and conflicts.
|
|
skipCertManagerInstall = os.Getenv("CERT_MANAGER_INSTALL_SKIP") == "true"
|
|
// isCertManagerAlreadyInstalled will be set true when CertManager CRDs be found on the cluster
|
|
isCertManagerAlreadyInstalled = false
|
|
|
|
// projectImage is the name of the image which will be build and loaded
|
|
// with the code source changes to be tested.
|
|
projectImage = "docker.io/netbirdio/kubernetes-operator:e2e"
|
|
)
|
|
|
|
// TestE2E runs the end-to-end (e2e) test suite for the project. These tests execute in an isolated,
|
|
// temporary environment to validate project changes with the the purposed to be used in CI jobs.
|
|
// The default setup requires Kind, builds/loads the Manager Docker image locally, and installs
|
|
// CertManager.
|
|
func TestE2E(t *testing.T) {
|
|
RegisterFailHandler(Fail)
|
|
_, _ = fmt.Fprintf(GinkgoWriter, "Starting operator integration test suite\n")
|
|
RunSpecs(t, "e2e suite")
|
|
}
|
|
|
|
var _ = BeforeSuite(func() {
|
|
By("building the manager(Operator) image")
|
|
cmd := exec.Command("make", "docker-build", fmt.Sprintf("IMG=%s", projectImage))
|
|
_, err := utils.Run(cmd)
|
|
ExpectWithOffset(1, err).NotTo(HaveOccurred(), "Failed to build the manager(Operator) image")
|
|
|
|
By("loading the manager(Operator) image on Kind")
|
|
err = utils.LoadImageToKindClusterWithName(projectImage)
|
|
ExpectWithOffset(1, err).NotTo(HaveOccurred(), "Failed to load the manager(Operator) image into Kind")
|
|
|
|
if !skipCertManagerInstall {
|
|
By("checking if cert manager is installed already")
|
|
isCertManagerAlreadyInstalled = utils.IsCertManagerCRDsInstalled()
|
|
if !isCertManagerAlreadyInstalled {
|
|
_, _ = fmt.Fprintf(GinkgoWriter, "Installing CertManager...\n")
|
|
Expect(utils.InstallCertManager()).To(Succeed(), "Failed to install CertManager")
|
|
} else {
|
|
_, _ = fmt.Fprintf(GinkgoWriter, "WARNING: CertManager is already installed. Skipping installation...\n")
|
|
}
|
|
}
|
|
|
|
By("starting up the test management")
|
|
cmd = exec.Command("docker", "compose", "up", "-d")
|
|
curDir, err := utils.GetProjectDir()
|
|
Expect(err).NotTo(HaveOccurred())
|
|
cmd.Dir = path.Join(curDir, "test", "utils", "management")
|
|
out, err := cmd.CombinedOutput()
|
|
Expect(err).NotTo(HaveOccurred(), string(out))
|
|
|
|
Eventually(func() error {
|
|
client := netbird.New("http://127.0.0.1:8080", apiToken)
|
|
_, err = client.Accounts.List(context.Background())
|
|
return err
|
|
}).Should(Succeed())
|
|
})
|
|
|
|
var _ = AfterSuite(func() {
|
|
// Teardown CertManager after the suite if not skipped and if it was not already installed
|
|
if !skipCertManagerInstall && !isCertManagerAlreadyInstalled {
|
|
_, _ = fmt.Fprintf(GinkgoWriter, "Uninstalling CertManager...\n")
|
|
utils.UninstallCertManager()
|
|
}
|
|
|
|
cmd := exec.Command("docker", "compose", "down")
|
|
curDir, err := utils.GetProjectDir()
|
|
Expect(err).NotTo(HaveOccurred())
|
|
cmd.Dir = path.Join(curDir, "test", "utils", "management")
|
|
out, err := cmd.CombinedOutput()
|
|
Expect(err).NotTo(HaveOccurred(), string(out))
|
|
})
|