Add unit tests for Exchange, Binding & Queue in RabbitMQ cluster namespace

Signed-off-by: Gerhard Lazu <[email protected]>

Author: gvmw

pkg/reconciler/broker/resources/exchange_test.go

@@ -70,6 +70,51 @@ func TestNewExchange(t *testing.T) {
 				},
 			},
 		},
+	}, {
+		name: "broker exchange in RabbitMQ cluster namespace",
+		args: &resources.ExchangeArgs{
+			Name:                     brokerName,
+			Namespace:                namespace,
+			RabbitMQClusterName:      rabbitmqcluster,
+			RabbitMQClusterNamespace: "single-rabbitmq-cluster",
+			Broker: &eventingv1.Broker{
+				ObjectMeta: metav1.ObjectMeta{
+					Name:      brokerName,
+					Namespace: namespace,
+					UID:       brokerUID,
+				},
+				Spec: eventingv1.BrokerSpec{
+					Config: &duckv1.KReference{
+						Name: rabbitmqcluster,
+					},
+				},
+			},
+		},
+		want: &rabbitv1beta1.Exchange{
+			ObjectMeta: metav1.ObjectMeta{
+				Name:      brokerName,
+				Namespace: namespace,
+				OwnerReferences: []metav1.OwnerReference{
+					{
+						Kind:       "Broker",
+						APIVersion: "eventing.knative.dev/v1",
+						Name:       brokerName,
+						UID:        brokerUID,
+					},
+				},
+				Labels: map[string]string{"eventing.knative.dev/broker": "testbroker"},
+			},
+			Spec: rabbitv1beta1.ExchangeSpec{
+				Name:       brokerName,
+				Type:       "headers",
+				Durable:    true,
+				AutoDelete: false,
+				RabbitmqClusterReference: rabbitv1beta1.RabbitmqClusterReference{
+					Name:      rabbitmqcluster,
+					Namespace: "single-rabbitmq-cluster",
+				},
+			},
+		},
 	}, {
 		name: "trigger exchange",
 		args: &resources.ExchangeArgs{

pkg/reconciler/trigger/resources/binding_test.go

@@ -83,6 +83,50 @@ func TestNewBinding(t *testing.T) {
 				},
 			},
 		},
+		{
+			name: "Creates a binding in RabbitMQ cluster namespace",
+			args: &resources.BindingArgs{
+				Namespace:                namespace,
+				Name:                     "name",
+				RabbitMQClusterName:      rabbitmqcluster,
+				RabbitMQClusterNamespace: "single-rabbitmq-cluster",
+				Labels:                   map[string]string{"label": "cool"},
+				Owner: metav1.OwnerReference{
+					Kind:       "Broker",
+					APIVersion: "eventing.knative.dev/v1",
+					Name:       brokerName,
+					UID:        brokerUID,
+				},
+				Source:      "source",
+				Destination: "destination",
+			},
+			want: &rabbitv1beta1.Binding{
+				ObjectMeta: metav1.ObjectMeta{
+					Namespace: namespace,
+					Name:      "name",
+					OwnerReferences: []metav1.OwnerReference{
+						{
+							Kind:       "Broker",
+							APIVersion: "eventing.knative.dev/v1",
+							Name:       brokerName,
+							UID:        brokerUID,
+						},
+					},
+					Labels: map[string]string{"label": "cool"},
+				},
+				Spec: rabbitv1beta1.BindingSpec{
+					Vhost:           "/",
+					Source:          "source",
+					Destination:     "destination",
+					DestinationType: "queue",
+					RabbitmqClusterReference: rabbitv1beta1.RabbitmqClusterReference{
+						Name:      rabbitmqcluster,
+						Namespace: "single-rabbitmq-cluster",
+					},
+					Arguments: &runtime.RawExtension{Raw: []byte(`{"x-match":"all"}`)},
+				},
+			},
+		},
 		{
 			name: "appends to filters if given",
 			args: &resources.BindingArgs{

pkg/reconciler/trigger/resources/queue_test.go

@@ -74,6 +74,34 @@ func TestNewQueue(t *testing.T) {
 				},
 			},
 		},
+		{
+			name: "creates a queue in RabbitMQ cluster namespace",
+			args: &resources.QueueArgs{
+				Name:                     triggerName,
+				Namespace:                namespace,
+				RabbitMQClusterName:      rabbitmqcluster,
+				RabbitMQClusterNamespace: "single-rabbitmq-cluster",
+				Owner:                    owner,
+				Labels:                   map[string]string{"cool": "label"},
+			},
+			want: &rabbitv1beta1.Queue{
+				ObjectMeta: metav1.ObjectMeta{
+					Name:            triggerName,
+					Namespace:       namespace,
+					OwnerReferences: []metav1.OwnerReference{owner},
+					Labels:          map[string]string{"cool": "label"},
+				},
+				Spec: rabbitv1beta1.QueueSpec{
+					Name:       triggerName,
+					Durable:    true,
+					AutoDelete: false,
+					RabbitmqClusterReference: rabbitv1beta1.RabbitmqClusterReference{
+						Name:      rabbitmqcluster,
+						Namespace: "single-rabbitmq-cluster",
+					},
+				},
+			},
+		},
 		{
 			name: "adds a dead letter exchange if that is set",
 			args: &resources.QueueArgs{