Implement review comment v2

kyma-project · Jul 20, 2023 · 086efd4 · 086efd4
1 parent 74c0839
commit 086efd4
Show file tree

Hide file tree

Showing 2 changed files with 15 additions and 18 deletions.
diff --git a/internal/controller/eventing/integrationtests/validation/integration_test.go b/internal/controller/eventing/integrationtests/validation/integration_test.go
@@ -496,7 +496,7 @@ func Test_Validate_Defaulting(t *testing.T) {
 				},
 			},
 			wantMatches: gomega.And(
-				eventingMatchers.HaveBackendTypeNats(defaultBackend()),
+				eventingMatchers.HaveBackendTypeNats(defaultBackendConfig()),
 				eventingMatchers.HavePublisher(defaultPublisher()),
 				eventingMatchers.HavePublisherResources(defaultPublisherResources()),
 				eventingMatchers.HaveLogging(defaultLogging()),
@@ -516,7 +516,7 @@ func Test_Validate_Defaulting(t *testing.T) {
 				},
 			},
 			wantMatches: gomega.And(
-				eventingMatchers.HaveBackendTypeNats(defaultBackend()),
+				eventingMatchers.HaveBackendTypeNats(defaultBackendConfig()),
 				eventingMatchers.HavePublisher(defaultPublisher()),
 				eventingMatchers.HavePublisherResources(defaultPublisherResources()),
 				eventingMatchers.HaveLogging(defaultLogging()),
@@ -562,7 +562,7 @@ func Test_Validate_Defaulting(t *testing.T) {
 				},
 			},
 			wantMatches: gomega.And(
-				eventingMatchers.HaveBackendTypeNats(defaultBackend()),
+				eventingMatchers.HaveBackendTypeNats(defaultBackendConfig()),
 			),
 		},
 		{
@@ -670,15 +670,12 @@ func Test_Validate_Defaulting(t *testing.T) {
 	}
 }
 
-func defaultBackend() v1alpha1.Backend {
-	return v1alpha1.Backend{
-		Type: typeNats,
-		Config: v1alpha1.BackendConfig{
-			NATSStreamStorageType: storageTypeFile,
-			NATSStreamReplicas:    3,
-			NATSStreamMaxSize:     resource.MustParse("700Mi"),
-			NATSMaxMsgsPerTopic:   1000000,
-		},
+func defaultBackendConfig() v1alpha1.BackendConfig {
+	return v1alpha1.BackendConfig{
+		NATSStreamStorageType: storageTypeFile,
+		NATSStreamReplicas:    3,
+		NATSStreamMaxSize:     resource.MustParse("700Mi"),
+		NATSMaxMsgsPerTopic:   1000000,
 	}
 }
 

diff --git a/test/matchers/matchers.go b/test/matchers/matchers.go
@@ -8,28 +8,28 @@ import (
 	"k8s.io/apimachinery/pkg/api/resource"
 )
 
-func HaveBackendTypeNats(b v1alpha1.Backend) gomegatypes.GomegaMatcher {
+func HaveBackendTypeNats(bc v1alpha1.BackendConfig) gomegatypes.GomegaMatcher {
 	return gomega.And(
 		gomega.WithTransform(
 			func(e *v1alpha1.Eventing) string {
 				return e.Spec.Backends.Type
-			}, gomega.Equal(b.Type)),
+			}, gomega.Equal("NATS")),
 		gomega.WithTransform(
 			func(e *v1alpha1.Eventing) string {
 				return e.Spec.Backends.Config.NATSStreamStorageType
-			}, gomega.Equal(b.Config.NATSStreamStorageType)),
+			}, gomega.Equal(bc.NATSStreamStorageType)),
 		gomega.WithTransform(
 			func(e *v1alpha1.Eventing) int {
 				return e.Spec.Backends.Config.NATSStreamReplicas
-			}, gomega.Equal(b.Config.NATSStreamReplicas)),
+			}, gomega.Equal(bc.NATSStreamReplicas)),
 		gomega.WithTransform(
 			func(e *v1alpha1.Eventing) resource.Quantity {
 				return e.Spec.Backends.Config.NATSStreamMaxSize
-			}, gomega.Equal(b.Config.NATSStreamMaxSize)),
+			}, gomega.Equal(bc.NATSStreamMaxSize)),
 		gomega.WithTransform(
 			func(e *v1alpha1.Eventing) int {
 				return e.Spec.Backends.Config.NATSMaxMsgsPerTopic
-			}, gomega.Equal(b.Config.NATSMaxMsgsPerTopic)),
+			}, gomega.Equal(bc.NATSMaxMsgsPerTopic)),
 	)
 }