Added CustomMatcher for asserting on k8 errors

Author: harishsurf

test/e2e/bundle_e2e_test.go

@@ -64,15 +64,13 @@ var _ = Describe("Installing bundles with new object types", func() {
 			err = json.Unmarshal(data, &vpaCRD)
 			Expect(err).ToNot(HaveOccurred(), "could not convert vpa crd to unstructured")
 
-			Eventually(func() error {
-				err := ctx.Ctx().Client().Create(context.TODO(), &vpaCRD)
+			Eventually(func() bool {
+				err = ctx.Ctx().Client().Create(context.TODO(), &vpaCRD)
 				if err != nil {
-					if !k8serrors.IsAlreadyExists(err) {
-						return err
-					}
+					return k8serrors.IsAlreadyExists(err)
 				}
-				return nil
-			}).Should(Succeed())
+				return true
+			}).Should(BeTrue())
 
 			// ensure vpa crd is established and accepted on the cluster before continuing
 			Eventually(func() (bool, error) {

test/e2e/gc_e2e_test.go

@@ -3,10 +3,15 @@ package e2e
 import (
 	"context"
 	"fmt"
-
 	"github.com/blang/semver"
 	. "github.com/onsi/ginkgo"
 	. "github.com/onsi/gomega"
+	"github.com/onsi/gomega/types"
+	"github.com/operator-framework/api/pkg/operators/v1alpha1"
+	"github.com/operator-framework/operator-lifecycle-manager/pkg/api/client/clientset/versioned"
+	"github.com/operator-framework/operator-lifecycle-manager/pkg/lib/operatorclient"
+	"github.com/operator-framework/operator-lifecycle-manager/pkg/lib/ownerutil"
+	"github.com/operator-framework/operator-lifecycle-manager/test/e2e/ctx"
 	. "github.com/operator-framework/operator-lifecycle-manager/test/e2e/dsl"
 	corev1 "k8s.io/api/core/v1"
 	rbacv1 "k8s.io/api/rbac/v1"
@@ -15,14 +20,13 @@ import (
 	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
 	"k8s.io/apimachinery/pkg/util/rand"
 	apiregistrationv1 "k8s.io/kube-aggregator/pkg/apis/apiregistration/v1"
-
-	"github.com/operator-framework/api/pkg/operators/v1alpha1"
-	"github.com/operator-framework/operator-lifecycle-manager/pkg/api/client/clientset/versioned"
-	"github.com/operator-framework/operator-lifecycle-manager/pkg/lib/operatorclient"
-	"github.com/operator-framework/operator-lifecycle-manager/pkg/lib/ownerutil"
-	"github.com/operator-framework/operator-lifecycle-manager/test/e2e/ctx"
+	"reflect"
+	"runtime"
+	"strings"
 )
 
+const k8ErrorImportPath = "k8s.io/apimachinery/pkg/api/errors."
+
 var _ = Describe("Garbage collection for dependent resources", func() {
 	var (
 		kubeClient     operatorclient.ClientInterface
@@ -276,7 +280,7 @@ var _ = Describe("Garbage collection for dependent resources", func() {
 			It("should have deleted the dependent since both the owners were deleted", func() {
 				_, err := kubeClient.KubernetesInterface().CoreV1().ConfigMaps(testNamespace).Get(context.TODO(), dependent.GetName(), metav1.GetOptions{})
 				Expect(err).To(HaveOccurred())
-				Expect(k8serrors.IsNotFound(err)).To(BeTrue())
+				Expect(k8serrors.IsNotFound).Should(assertOnk8Error("IsNotFound", err))
 				ctx.Ctx().Logf("dependent successfully garbage collected after both owners were deleted")
 			})
 
@@ -602,3 +606,14 @@ var _ = Describe("Garbage collection for dependent resources", func() {
 		})
 	})
 })
+
+func assertOnk8Error(expectedk8Error string, actualError error) types.GomegaMatcher {
+	return WithTransform(func(f func(e error) bool) string {
+		var errFuncName string
+		if f(actualError) {
+			errFuncName = runtime.FuncForPC(reflect.ValueOf(f).Pointer()).Name()
+			errFuncName = strings.Split(errFuncName, k8ErrorImportPath)[1]
+		}
+		return errFuncName
+	}, Equal(expectedk8Error))
+}

test/e2e/scoped_client_test.go

@@ -6,6 +6,7 @@ import (
 
 	. "github.com/onsi/ginkgo"
 	"github.com/onsi/ginkgo/extensions/table"
+	. "github.com/onsi/gomega"
 	"github.com/sirupsen/logrus"
 	"github.com/stretchr/testify/require"
 	corev1 "k8s.io/api/core/v1"
@@ -61,7 +62,7 @@ var _ = Describe("Scoped Client", func() {
 			// lack of permission.
 			name: "ServiceAccountDoesNotHaveAnyPermission",
 			assertFunc: func(errGot error) {
-				require.True(GinkgoT(), k8serrors.IsForbidden(errGot))
+				Expect(k8serrors.IsForbidden).Should(assertOnk8Error("IsForbidden", errGot))
 			},
 		}),
 		table.Entry("ServiceAccountHasPermission", testParameter{
@@ -73,7 +74,7 @@ var _ = Describe("Scoped Client", func() {
 				return
 			},
 			assertFunc: func(errGot error) {
-				require.True(GinkgoT(), k8serrors.IsNotFound(errGot))
+				Expect(k8serrors.IsNotFound).Should(assertOnk8Error("IsNotFound", errGot))
 			},
 		}),
 	}