Add some tests

.github/workflows/e2e.yml

@@ -82,3 +82,67 @@ jobs:
         if: failure()
         run: |
           kubectl get eventing -n kyma-system -o yaml
+
+  PeerAuthentication:
+    runs-on: ubuntu-latest
+
+    steps:
+      - uses: actions/checkout@v4
+
+      - name: Install k3d tools
+        run: |
+          make -C hack/ci/ install-k3d-tools
+
+      - name: Install Istio
+        run: |
+          helm repo add istio https://istio-release.storage.googleapis.com/charts
+          helm repo update
+          kubectl create namespace istio-system
+          helm install istio-base istio/base -n istio-system --set defaultRevision=default
+
+      - name: Install Kyma CLI & setup k3d cluster using kyma CLI
+        run: |
+          make kyma
+          make -C hack/ci/ create-k3d
+          kubectl version
+          kubectl cluster-info
+
+      - name: Install eventing-manager
+        run: |
+          make install IMG=$MANAGER_IMAGE
+
+      - name: Wait for the 'pull-eventing-manager-build' job to succeed
+        uses: kyma-project/wait-for-commit-status-action@2b3ffe09af8b6f40e1213d5fb7f91a7bd41ffb20
+        with:
+          context: "pull-eventing-manager-build"
+          commit_ref: "${{ github.event.pull_request.head.sha }}" # Note: 'github.event.pull_request.head.sha' is not same as 'github.sha' on pull requests.
+          timeout: 600000 # 10 minutes in milliseconds
+          # The check interval is kept long otherwise it will exhaust the GitHub rate limit (More info: https://docs.github.com/en/rest/overview/resources-in-the-rest-api?apiVersion=2022-11-28#rate-limiting)
+          check_interval: 60000 # 1 minute in milliseconds
+        env:
+          GITHUB_TOKEN: "${{ secrets.GITHUB_TOKEN }}"
+          GITHUB_OWNER: "${{ github.repository_owner }}"
+          GITHUB_REPO: "eventing-manager"
+
+      - name: Deploy the controller to the cluster
+        run: |
+          kubectl create ns kyma-system || true
+          make deploy IMG=$MANAGER_IMAGE
+
+      - name: Setup NATS
+        run: |
+          make -C hack/ci/ get-nats-via-lifecycle-manager
+
+      - name: Setup and test the eventing-manager
+        run: |
+          e2e-setup-with-pa
+
+      - name: On error get NATS CR
+        if: failure()
+        run: |
+          kubectl get nats -n kyma-system -o yaml
+
+      - name: On error get eventing CR
+        if: failure()
+        run: |
+          kubectl get eventing -n kyma-system -o yaml

Makefile

@@ -288,6 +288,10 @@ $(KYMA):
 e2e-setup:
 	go test -v ./hack/e2e/setup/setup_test.go --tags=e2e
 
+.PHONY: e2e-setup-with-pa
+e2e-setup-with-pa:
+	go test -v ./hack/e2e/setup/setup_test.go --tags=e2e --peerauthentication
+
 # e2e-cleanup will delete the Eventing CR and check if the required resources are de-provisioned or not.
 .PHONY: e2e-cleanup
 e2e-cleanup: e2e-eventing-cleanup

hack/e2e/cleanup/cleanup_test.go

@@ -12,14 +12,15 @@ import (
 	"os"
 	"testing"
 
-	eventingv1alpha1 "github.com/kyma-project/eventing-manager/api/v1alpha1"
-	"github.com/kyma-project/eventing-manager/hack/e2e/common/testenvironment"
-	"github.com/kyma-project/eventing-manager/pkg/eventing"
 	"github.com/pkg/errors"
 	"github.com/stretchr/testify/require"
 	k8serrors "k8s.io/apimachinery/pkg/api/errors"
 	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
 
+	eventingv1alpha1 "github.com/kyma-project/eventing-manager/api/v1alpha1"
+	"github.com/kyma-project/eventing-manager/hack/e2e/common/testenvironment"
+	"github.com/kyma-project/eventing-manager/pkg/eventing"
+
 	. "github.com/kyma-project/eventing-manager/hack/e2e/common"
 	. "github.com/kyma-project/eventing-manager/hack/e2e/common/fixtures"
 )

hack/e2e/common/k8s.go

@@ -18,20 +18,23 @@ import (
 	natsv1alpha1 "github.com/kyma-project/nats-manager/api/v1alpha1"
 )
 
-func GetK8sClients() (*kubernetes.Clientset, client.Client, error) {
+func GetRestConfig() (*rest.Config, error) {
 	kubeConfigPath := ""
 	if _, ok := os.LookupEnv("KUBECONFIG"); ok {
 		kubeConfigPath = os.Getenv("KUBECONFIG")
 	} else {
 		userHomeDir, err := os.UserHomeDir()
 		if err != nil {
-			return nil, nil, err
+			return nil, err
 		}
 		kubeConfigPath = filepath.Join(userHomeDir, ".kube", "config")
 	}
 
-	var kubeConfig *rest.Config
-	kubeConfig, err := clientcmd.BuildConfigFromFlags("", kubeConfigPath)
+	return clientcmd.BuildConfigFromFlags("", kubeConfigPath)
+}
+
+func GetK8sClients() (*kubernetes.Clientset, client.Client, error) {
+	kubeConfig, err := GetRestConfig()
 	if err != nil {
 		return nil, nil, err
 	}
@@ -77,3 +80,5 @@ func GetK8sClients() (*kubernetes.Clientset, client.Client, error) {
 
 	return clientSet, k8sClient, nil
 }
+
+

hack/e2e/eventing/cleanup/cleanup_test.go

@@ -7,8 +7,9 @@ import (
 	"os"
 	"testing"
 
-	"github.com/kyma-project/eventing-manager/hack/e2e/common/testenvironment"
 	"github.com/stretchr/testify/require"
+
+	"github.com/kyma-project/eventing-manager/hack/e2e/common/testenvironment"
 )
 
 var testEnvironment *testenvironment.TestEnvironment