mirror of
https://github.com/fluxcd/flux2.git
synced 2026-02-10 17:57:29 +00:00
e8d6d5fe5c
Remove use of the fake client, and replace with a real client connected to the testEnv. This required fixes to the yaml files as the testEnv has stricter verifcation of objects. This also meant it was not possible to test a GitRepository with a missing artifact since that is not a valid state. The tests are slower than before, taking around 7-10 seconds each because the testEnv is setup and destroyed for every test. These will be sped up in a follow up PR. Signed-off-by: Allen Porter <allen@thebends.org>
59 lines
1.7 KiB
Go
59 lines
1.7 KiB
Go
// +build e2e
|
|
|
|
package main
|
|
|
|
import (
|
|
"context"
|
|
"fmt"
|
|
"os"
|
|
"testing"
|
|
|
|
"github.com/fluxcd/flux2/internal/utils"
|
|
)
|
|
|
|
func TestMain(m *testing.M) {
|
|
// Ensure tests print consistent timestamps regardless of timezone
|
|
os.Setenv("TZ", "UTC")
|
|
|
|
// Install Flux.
|
|
// Creating the test env manager sets rootArgs client flags
|
|
_, err := NewTestEnvKubeManager(ExistingClusterMode)
|
|
if err != nil {
|
|
panic(fmt.Errorf("error creating kube manager: '%w'", err))
|
|
}
|
|
output, err := executeCommand("install --components-extra=image-reflector-controller,image-automation-controller")
|
|
if err != nil {
|
|
panic(fmt.Errorf("install falied: %s error:'%w'", output, err))
|
|
}
|
|
|
|
// Run tests
|
|
code := m.Run()
|
|
|
|
// Uninstall Flux
|
|
output, err = executeCommand("uninstall -s --keep-namespace")
|
|
if err != nil {
|
|
panic(fmt.Errorf("uninstall falied: %s error:'%w'", output, err))
|
|
}
|
|
|
|
// Delete namespace and wait for finalisation
|
|
kubectlArgs := []string{"delete", "namespace", "flux-system"}
|
|
_, err = utils.ExecKubectlCommand(context.TODO(), utils.ModeStderrOS, rootArgs.kubeconfig, rootArgs.kubecontext, kubectlArgs...)
|
|
if err != nil {
|
|
panic(fmt.Errorf("delete namespace error:'%w'", err))
|
|
}
|
|
|
|
os.Exit(code)
|
|
}
|
|
|
|
func setupTestNamespace(namespace string) (func(), error) {
|
|
kubectlArgs := []string{"create", "namespace", namespace}
|
|
_, err := utils.ExecKubectlCommand(context.TODO(), utils.ModeStderrOS, rootArgs.kubeconfig, rootArgs.kubecontext, kubectlArgs...)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
|
|
return func() {
|
|
kubectlArgs := []string{"delete", "namespace", namespace}
|
|
utils.ExecKubectlCommand(context.TODO(), utils.ModeCapture, rootArgs.kubeconfig, rootArgs.kubecontext, kubectlArgs...)
|
|
}, nil
|
|
}
|