test: add new e2e test cases for kubectl plugin

Signed-off-by: Venkatesh Jayagopal <venkatesh.jayagopal@suse.com>

Author: venkateshjayagopal

test/e2e/e2e_suite_test.go

@@ -5,6 +5,8 @@ import (
 	"fmt"
 	"log/slog"
 	"os"
+	"os/exec"
+	"path/filepath"
 	"slices"
 	"strings"
 	"testing"
@@ -49,6 +51,19 @@ func installDependencies() bool {
 	return os.Getenv("E2E_SKIP_DEPENDENCIES") != "true"
 }
 
+func makeKubectlPlugin() error {
+	projectRoot := filepath.Join("..", "..")
+	cmd := exec.Command("make", "kubectl-plugin")
+	cmd.Dir = projectRoot
+	cmd.Stdout = os.Stdout
+	cmd.Stderr = os.Stderr
+
+	if err := cmd.Run(); err != nil {
+		return fmt.Errorf("failed to run make kubectl-plugin: %w", err)
+	}
+	return nil
+}
+
 type helmChart struct {
 	name          string
 	namespace     string
@@ -115,7 +130,11 @@ func getCharts() []helmChart {
 }
 
 func TestMain(m *testing.M) {
+	// we build kubectl_runtime-enforcer binary to run plugin e2e tests
+	makeKubectlPlugin()
+
 	charts := getCharts()
+
 	commonSetupFuncs := []env.Func{
 		// we uninstall here as a defensive check but nothing should be left behind
 		uninstallHelmRepos(charts),
@@ -226,11 +245,19 @@ func installHelmRepos(charts []helmChart) env.Func {
 			if strings.HasPrefix(chartPath, "/") {
 				// First we try to add the repo.
 				if err = manager.RunRepo(helm.WithArgs("add", chart.repoLocalName, chart.repoURL)); err != nil {
-					return ctx, fmt.Errorf("failed to add local repo '%s': %w", chart.repoLocalName, err)
+					return ctx, fmt.Errorf(
+						"failed to add local repo '%s': %w",
+						chart.repoLocalName,
+						err,
+					)
 				}
 				// Update the repo.
 				if err = manager.RunRepo(helm.WithArgs("update")); err != nil {
-					return ctx, fmt.Errorf("failed to update local repo '%s': %w", chart.repoLocalName, err)
+					return ctx, fmt.Errorf(
+						"failed to update local repo '%s': %w",
+						chart.repoLocalName,
+						err,
+					)
 				}
 				// The final chart path will be the name of repoLocalName + chartPath
 				chartPath = chart.repoLocalName + chartPath

test/e2e/e2e_test.go

@@ -64,3 +64,37 @@ func TestOtelCollector(t *testing.T) {
 
 	testEnv.Test(t, getOtelCollectorTest())
 }
+
+func TestKubectlPluginProposalPromoteTest(t *testing.T) {
+	t.Log("test kubectl runtime-enforcer proposal promote PROPOSAL_NAME [flags]")
+
+	testEnv.Test(t, getKubectlPluginProposalPromoteTest())
+}
+
+func TestKubectlPluginPolicyModeTest(t *testing.T) {
+	t.Log("test kubectl runtime-enforcer policy monitor POLICY_NAME [flags]")
+
+	testEnv.Test(t, getKubectlPluginPolicyModeTest())
+}
+
+func TestKubectlPluginPolicyExecAllowTest(t *testing.T) {
+	t.Log(
+		"test kubectl runtime-enforcer policy allow POLICY_NAME <container-name> <executable-name> [<executable-name>...] [flags]",
+	)
+
+	testEnv.Test(t, getKubectlPluginPolicyExecAllowTest())
+}
+
+func TestKubectlPluginPolicyExecDenyTest(t *testing.T) {
+	t.Log(
+		"test kubectl runtime-enforcer policy deny POLICY_NAME <container-name> <executable-name> [<executable-name>...] [flags]",
+	)
+
+	testEnv.Test(t, getKubectlPluginPolicyExecDenyTest())
+}
+
+func TestKubectlPluginErrorHandlingTest(t *testing.T) {
+	t.Log("test kubectl runtime-enforcer ERROR handling")
+
+	testEnv.Test(t, getKubectlPluginErrorHandlingTest())
+}