From 20675ff8b5e629ddbedb8e036c40ae23a0c39205 Mon Sep 17 00:00:00 2001
From: Martin Schuppert <mschuppert@redhat.com>
Date: Mon, 13 Sep 2021 13:04:16 +0000
Subject: [PATCH] Watch OSNet CRs to reconcile OSMacAddr CR

---
 controllers/openstackmacaddress_controller.go | 35 +++++++++++++++++--
 1 file changed, 33 insertions(+), 2 deletions(-)

diff --git a/controllers/openstackmacaddress_controller.go b/controllers/openstackmacaddress_controller.go
index 9b2d74676..7d57f0a35 100644
--- a/controllers/openstackmacaddress_controller.go
+++ b/controllers/openstackmacaddress_controller.go
@@ -30,6 +30,7 @@ import (
 	ctrl "sigs.k8s.io/controller-runtime"
 	"sigs.k8s.io/controller-runtime/pkg/client"
 	"sigs.k8s.io/controller-runtime/pkg/handler"
+	"sigs.k8s.io/controller-runtime/pkg/reconcile"
 	"sigs.k8s.io/controller-runtime/pkg/source"
 
 	ospdirectorv1beta1 "github.com/openstack-k8s-operators/osp-director-operator/api/v1beta1"
@@ -209,10 +210,40 @@ func (r *OpenStackMACAddressReconciler) Reconcile(ctx context.Context, req ctrl.
 
 // SetupWithManager sets up the controller with the Manager.
 func (r *OpenStackMACAddressReconciler) SetupWithManager(mgr ctrl.Manager) error {
+
+	namespacedFn := handler.EnqueueRequestsFromMapFunc(func(o client.Object) []reconcile.Request {
+		result := []reconcile.Request{}
+
+		// get all CRs from the same namespace, right now there should only be one
+		crs := &ospdirectorv1beta1.OpenStackMACAddressList{}
+		listOpts := []client.ListOption{
+			client.InNamespace(o.GetNamespace()),
+		}
+		if err := r.Client.List(context.Background(), crs, listOpts...); err != nil {
+			r.Log.Error(err, "Unable to retrieve CRs %v")
+			return nil
+		}
+
+		for _, cr := range crs.Items {
+			if o.GetNamespace() == cr.Namespace {
+				// return namespace and Name of CR
+				name := client.ObjectKey{
+					Namespace: cr.Namespace,
+					Name:      cr.Name,
+				}
+				result = append(result, reconcile.Request{NamespacedName: name})
+			}
+		}
+		if len(result) > 0 {
+			return result
+		}
+		return nil
+	})
+
 	return ctrl.NewControllerManagedBy(mgr).
 		For(&ospdirectorv1beta1.OpenStackMACAddress{}).
-		Watches(&source.Kind{Type: &ospdirectorv1beta1.OpenStackIPSet{}}, &handler.EnqueueRequestForObject{}).
-		Watches(&source.Kind{Type: &ospdirectorv1beta1.OpenStackNet{}}, &handler.EnqueueRequestForObject{}).
+		// Watch OpenStackNet to create/delete MAC
+		Watches(&source.Kind{Type: &ospdirectorv1beta1.OpenStackNet{}}, namespacedFn).
 		Complete(r)
 }