Replace unit test assertions with Gomega matchers (#1046)

Problem: There were still some existing unit tests that weren't using the Gomega
matcher library for assertions.

Solution: Changed existing tests to use the Gomega matcher library, replaced deprecated
NewGomegaWithT with NewWithT, and added sub-tests to existing tests.

Author: bjee19

cmd/gateway/commands_test.go

@@ -16,7 +16,7 @@ type flagTestCase struct {
 }
 
 func testFlag(t *testing.T, cmd *cobra.Command, test flagTestCase) {
-	g := NewGomegaWithT(t)
+	g := NewWithT(t)
 	// discard any output generated by cobra
 	cmd.SetOut(io.Discard)
 	cmd.SetErr(io.Discard)

cmd/gateway/validation_test.go

@@ -52,7 +52,7 @@ func TestValidateGatewayControllerName(t *testing.T) {
 
 	for _, test := range tests {
 		t.Run(test.name, func(t *testing.T) {
-			g := NewGomegaWithT(t)
+			g := NewWithT(t)
 
 			err := validateGatewayControllerName(test.value)
 
@@ -115,7 +115,7 @@ func TestValidateResourceName(t *testing.T) {
 
 	for _, test := range tests {
 		t.Run(test.name, func(t *testing.T) {
-			g := NewGomegaWithT(t)
+			g := NewWithT(t)
 
 			err := validateResourceName(test.value)
 
@@ -178,7 +178,7 @@ func TestValidateNamespaceName(t *testing.T) {
 
 	for _, test := range tests {
 		t.Run(test.name, func(t *testing.T) {
-			g := NewGomegaWithT(t)
+			g := NewWithT(t)
 
 			err := validateNamespaceName(test.value)
 
@@ -240,7 +240,7 @@ func TestParseNamespacedResourceName(t *testing.T) {
 
 	for _, test := range tests {
 		t.Run(test.name, func(t *testing.T) {
-			g := NewGomegaWithT(t)
+			g := NewWithT(t)
 
 			nsName, err := parseNamespacedResourceName(test.value)
 
@@ -283,7 +283,7 @@ func TestValidateIP(t *testing.T) {
 
 	for _, tc := range tests {
 		t.Run(tc.name, func(t *testing.T) {
-			g := NewGomegaWithT(t)
+			g := NewWithT(t)
 
 			err := validateIP(tc.ip)
 			if !tc.expErr {
@@ -320,7 +320,7 @@ func TestValidatePort(t *testing.T) {
 
 	for _, tc := range tests {
 		t.Run(tc.name, func(t *testing.T) {
-			g := NewGomegaWithT(t)
+			g := NewWithT(t)
 
 			err := validatePort(tc.port)
 			if !tc.expErr {

conformance/tests/conformance_test.go

@@ -35,7 +35,7 @@ import (
 )
 
 func TestConformance(t *testing.T) {
-	g := NewGomegaWithT(t)
+	g := NewWithT(t)
 	cfg, err := config.GetConfig()
 	g.Expect(err).To(BeNil())
 

internal/framework/controller/filter/filter_test.go

@@ -10,10 +10,9 @@ import (
 func TestCreateSingleResourceFilter(t *testing.T) {
 	targetNsName := types.NamespacedName{Namespace: "test", Name: "resource"}
 
+	g := NewWithT(t)
 	filter := CreateSingleResourceFilter(targetNsName)
-	if filter == nil {
-		t.Fatal("TestCreateSingleResourceFilter() returned nil filter")
-	}
+	g.Expect(filter).ToNot(BeNil())
 
 	const expectedMsg = "Resource is ignored because this controller only supports a single resource " +
 		"test/resource of that type"
@@ -52,8 +51,7 @@ func TestCreateSingleResourceFilter(t *testing.T) {
 
 	for _, test := range tests {
 		t.Run(test.name, func(t *testing.T) {
-			g := NewGomegaWithT(t)
-
+			g := NewWithT(t)
 			shouldProcess, msg := filter(test.nsname)
 			g.Expect(shouldProcess).To(Equal(test.expectedShouldProcess))
 			g.Expect(msg).To(Equal(test.expectedMsg))

internal/framework/controller/index/endpointslice_test.go

@@ -3,7 +3,7 @@ package index
 import (
 	"testing"
 
-	"github.com/google/go-cmp/cmp"
+	. "github.com/onsi/gomega"
 	v1 "k8s.io/api/core/v1"
 	discoveryV1 "k8s.io/api/discovery/v1"
 	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
@@ -42,18 +42,16 @@ func TestServiceNameIndexFunc(t *testing.T) {
 	}
 
 	for _, tc := range testcases {
+		g := NewWithT(t)
 		output := ServiceNameIndexFunc(tc.obj)
-		if diff := cmp.Diff(tc.expOutput, output); diff != "" {
-			t.Errorf("ServiceNameIndexFunc() mismatch on %q (-want +got):\n%s", tc.msg, diff)
-		}
+		g.Expect(output).To(Equal(tc.expOutput))
 	}
 }
 
 func TestServiceNameIndexFuncPanics(t *testing.T) {
 	defer func() {
-		if r := recover(); r == nil {
-			t.Errorf("ServiceNameIndexFunc() did not panic")
-		}
+		g := NewWithT(t)
+		g.Expect(recover()).ShouldNot(BeNil())
 	}()
 
 	ServiceNameIndexFunc(&v1.Namespace{})

internal/framework/controller/predicate/gatewayclass_test.go

@@ -9,7 +9,7 @@ import (
 )
 
 func TestGatewayClassPredicate(t *testing.T) {
-	g := NewGomegaWithT(t)
+	g := NewWithT(t)
 
 	p := GatewayClassPredicate{ControllerName: "nginx-ctlr"}
 

internal/framework/controller/predicate/service_test.go

@@ -226,7 +226,7 @@ func TestServicePortsChangedPredicate_Update(t *testing.T) {
 
 	for _, tc := range testcases {
 		t.Run(tc.msg, func(t *testing.T) {
-			g := NewGomegaWithT(t)
+			g := NewWithT(t)
 			update := p.Update(event.UpdateEvent{
 				ObjectOld: tc.objectOld,
 				ObjectNew: tc.objectNew,
@@ -238,7 +238,7 @@ func TestServicePortsChangedPredicate_Update(t *testing.T) {
 }
 
 func TestServicePortsChangedPredicate(t *testing.T) {
-	g := NewGomegaWithT(t)
+	g := NewWithT(t)
 
 	p := ServicePortsChangedPredicate{}
 

internal/framework/controller/register_test.go

@@ -98,7 +98,7 @@ func TestRegister(t *testing.T) {
 
 	for _, test := range tests {
 		t.Run(test.msg, func(t *testing.T) {
-			g := NewGomegaWithT(t)
+			g := NewWithT(t)
 
 			newReconciler := func(c controller.ReconcilerConfig) *controller.Reconciler {
 				g.Expect(c.Getter).To(BeIdenticalTo(test.fakes.mgr.GetClient()))

internal/framework/events/events_test.go

@@ -3,11 +3,12 @@ package events
 import (
 	"testing"
 
-	"github.com/google/go-cmp/cmp"
+	. "github.com/onsi/gomega"
 	"sigs.k8s.io/controller-runtime/pkg/log/zap"
 )
 
 func TestEventLoop_SwapBatches(t *testing.T) {
+	g := NewWithT(t)
 	eventLoop := NewEventLoop(nil, zap.New(), nil, nil)
 
 	eventLoop.currentBatch = EventBatch{
@@ -27,19 +28,8 @@ func TestEventLoop_SwapBatches(t *testing.T) {
 
 	eventLoop.swapBatches()
 
-	if l := len(eventLoop.currentBatch); l != 4 {
-		t.Errorf("EventLoop.swapBatches() mismatch. Expected 4 events in the current batch, got %d", l)
-	}
-
-	if diff := cmp.Diff(eventLoop.currentBatch, nextBatch); diff != "" {
-		t.Errorf("EventLoop.swapBatches() mismatch on current batch events (-want +got):\n%s", diff)
-	}
-
-	if l := len(eventLoop.nextBatch); l != 0 {
-		t.Errorf("EventLoop.swapBatches() mismatch. Expected 0 events in the next batch, got %d", l)
-	}
-
-	if c := cap(eventLoop.nextBatch); c != 3 {
-		t.Errorf("EventLoop.swapBatches() mismatch. Expected capacity of 3 in the next batch, got %d", c)
-	}
+	g.Expect(len(eventLoop.currentBatch)).To(Equal(len(nextBatch)))
+	g.Expect(eventLoop.currentBatch).To(Equal(nextBatch))
+	g.Expect(len(eventLoop.nextBatch)).To(Equal(0))
+	g.Expect(cap(eventLoop.nextBatch)).To(Equal(3))
 }

internal/framework/status/conditions_test.go

@@ -54,7 +54,7 @@ func CreateExpectedAPIConditions(
 }
 
 func TestConvertRouteConditions(t *testing.T) {
-	g := NewGomegaWithT(t)
+	g := NewWithT(t)
 
 	var generation int64 = 1
 	transitionTime := metav1.NewTime(time.Now())

internal/framework/status/gateway_test.go

@@ -52,7 +52,7 @@ func TestPrepareGatewayStatus(t *testing.T) {
 		Addresses: []v1beta1.GatewayStatusAddress{podIP},
 	}
 
-	g := NewGomegaWithT(t)
+	g := NewWithT(t)
 
 	result := prepareGatewayStatus(status, "1.2.3.4", transitionTime)
 	g.Expect(helpers.Diff(expected, result)).To(BeEmpty())

internal/framework/status/gatewayclass_test.go

@@ -22,7 +22,7 @@ func TestPrepareGatewayClassStatus(t *testing.T) {
 		Conditions: CreateExpectedAPIConditions("Test", 1, transitionTime),
 	}
 
-	g := NewGomegaWithT(t)
+	g := NewWithT(t)
 
 	result := prepareGatewayClassStatus(status, transitionTime)
 	g.Expect(helpers.Diff(expected, result)).To(BeEmpty())

internal/framework/status/httproute_test.go

@@ -60,7 +60,7 @@ func TestPrepareHTTPRouteStatus(t *testing.T) {
 		},
 	}
 
-	g := NewGomegaWithT(t)
+	g := NewWithT(t)
 
 	result := prepareHTTPRouteStatus(status, gatewayCtlrName, transitionTime)
 	g.Expect(helpers.Diff(expected, result)).To(BeEmpty())

internal/mode/static/build_statuses_test.go

@@ -193,7 +193,7 @@ func TestBuildStatuses(t *testing.T) {
 		},
 	}
 
-	g := NewGomegaWithT(t)
+	g := NewWithT(t)
 
 	var nginxReloadRes nginxReloadResult
 	result := buildStatuses(graph, nginxReloadRes)
@@ -285,7 +285,7 @@ func TestBuildStatusesNginxErr(t *testing.T) {
 		},
 	}
 
-	g := NewGomegaWithT(t)
+	g := NewWithT(t)
 
 	nginxReloadRes := nginxReloadResult{error: errors.New("test error")}
 	result := buildStatuses(graph, nginxReloadRes)
@@ -349,7 +349,7 @@ func TestBuildGatewayClassStatuses(t *testing.T) {
 
 	for _, test := range tests {
 		t.Run(test.name, func(t *testing.T) {
-			g := NewGomegaWithT(t)
+			g := NewWithT(t)
 
 			result := buildGatewayClassStatuses(test.gc, test.ignoredClasses)
 			g.Expect(helpers.Diff(test.expected, result)).To(BeEmpty())
@@ -556,7 +556,7 @@ func TestBuildGatewayStatuses(t *testing.T) {
 
 	for _, test := range tests {
 		t.Run(test.name, func(t *testing.T) {
-			g := NewGomegaWithT(t)
+			g := NewWithT(t)
 
 			result := buildGatewayStatuses(test.gateway, test.ignoredGateways, test.nginxReloadRes)
 			g.Expect(helpers.Diff(test.expected, result)).To(BeEmpty())

internal/mode/static/manager_test.go

@@ -63,7 +63,7 @@ func TestPrepareFirstEventBatchPreparerArgs(t *testing.T) {
 
 	for _, test := range tests {
 		t.Run(test.name, func(t *testing.T) {
-			g := NewGomegaWithT(t)
+			g := NewWithT(t)
 
 			objects, objectLists := prepareFirstEventBatchPreparerArgs(gcName, test.gwNsName)
 
@@ -112,7 +112,7 @@ func TestGetMetricsOptions(t *testing.T) {
 
 	for _, test := range tests {
 		t.Run(test.name, func(t *testing.T) {
-			g := NewGomegaWithT(t)
+			g := NewWithT(t)
 
 			metricsServerOptions := getMetricsOptions(test.metricsConfig)
 

internal/mode/static/nginx/config/execute_test.go

@@ -3,27 +3,24 @@ package config
 import (
 	"testing"
 
+	. "github.com/onsi/gomega"
+
 	"github.com/nginxinc/nginx-kubernetes-gateway/internal/mode/static/nginx/config/http"
 )
 
 func TestExecute(t *testing.T) {
+	g := NewWithT(t)
 	defer func() {
-		if r := recover(); r != nil {
-			t.Errorf("execute() panicked with %v", r)
-		}
+		g.Expect(recover()).Should(BeNil())
 	}()
-
 	bytes := execute(serversTemplate, []http.Server{})
-	if len(bytes) == 0 {
-		t.Error("template.execute() did not generate anything")
-	}
+	g.Expect(bytes).ToNot(BeEmpty())
 }
 
 func TestExecutePanics(t *testing.T) {
 	defer func() {
-		if r := recover(); r == nil {
-			t.Error("template.execute() did not panic")
-		}
+		g := NewWithT(t)
+		g.Expect(recover()).ShouldNot(BeNil())
 	}()
 
 	_ = execute(serversTemplate, "not-correct-data")

internal/mode/static/nginx/config/generator_test.go

@@ -60,7 +60,7 @@ func TestGenerate(t *testing.T) {
 			},
 		},
 	}
-	g := NewGomegaWithT(t)
+	g := NewWithT(t)
 
 	generator := config.NewGeneratorImpl()
 

internal/mode/static/nginx/config/maps_test.go

@@ -11,7 +11,7 @@ import (
 )
 
 func TestExecuteMaps(t *testing.T) {
-	g := NewGomegaWithT(t)
+	g := NewWithT(t)
 	pathRules := []dataplane.PathRule{
 		{
 			MatchRules: []dataplane.MatchRule{
@@ -95,7 +95,7 @@ func TestExecuteMaps(t *testing.T) {
 }
 
 func TestBuildAddHeaderMaps(t *testing.T) {
-	g := NewGomegaWithT(t)
+	g := NewWithT(t)
 	pathRules := []dataplane.PathRule{
 		{
 			MatchRules: []dataplane.MatchRule{