e2e_suite_test.go

package e2e_test

import (
	"flag"
	"fmt"
	"os"
	"os/exec"
	"testing"

	. "github.com/onsi/ginkgo"
	. "github.com/onsi/gomega"
	"github.com/spf13/cobra"

	opmroot "github.com/operator-framework/operator-registry/cmd/opm/root"
	"github.com/operator-framework/operator-registry/test/e2e/ctx"
)

// quay.io is the default registry used if no local registry endpoint is provided
// Note: login credentials are required to push/pull to quay
const defaultRegistry = "quay.io"

var (
	dockerUsername = os.Getenv("DOCKER_USERNAME")
	dockerPassword = os.Getenv("DOCKER_PASSWORD")
	dockerHost     = os.Getenv("DOCKER_REGISTRY_HOST") // 'DOCKER_HOST' is reserved for the docker daemon

	// opm command under test.
	opm *cobra.Command

	skipTLSForRegistry = flag.Bool("skip-tls", false, "skip TLS certificate verification for container image registries while pulling bundles or index")
)

func TestE2E(t *testing.T) {
	flag.Parse()
	RegisterFailHandler(Fail)
	RunSpecs(t, "E2E Suite")
}

var deprovision func() = func() {}

var _ = BeforeSuite(func() {
	// Configure test registry (hostnames, credentials, etc.)
	configureRegistry()
	deprovision = ctx.MustProvision(ctx.Ctx())

	opm = opmroot.NewCmd() // Creating multiple instances would cause flag registration conflicts
})

func configureRegistry() {
	switch {
	case dockerUsername == "" && dockerPassword == "" && dockerHost == "":
		// No registry credentials or local registry host provided
		// Fail early
		GinkgoT().Fatal("No registry credentials or local registry host provided")
	case dockerHost != "" && dockerUsername == "" && dockerPassword == "":
		// Running against local secure registry without credentials
		// No need to login
		return
	case dockerHost == "" && dockerUsername != "" && dockerPassword != "":
		// Set host to default registry
		dockerHost = defaultRegistry
	}

	// FIXME: Since podman login doesn't work with daemonless image pulling, we need to login with docker first so podman tests don't fail.
	dockerlogin := exec.Command("docker", "login", "-u", dockerUsername, "-p", dockerPassword, dockerHost)
	out, err := dockerlogin.CombinedOutput()
	Expect(err).ToNot(HaveOccurred(), "Error logging into %s: %s", dockerHost, out)

	By(fmt.Sprintf("Using container image registry %s", dockerHost))
}

var _ = AfterSuite(func() {
	deprovision()
})