From 0ca7eedd40bab2c2620a6ff8405c0fdbb21b8adf Mon Sep 17 00:00:00 2001
From: David Eads <deads@redhat.com>
Date: Fri, 13 Mar 2020 08:29:43 -0400
Subject: [PATCH] reconcile relatedObjects and place them in the
 clusteroperator for CVO

---
 ...ne-config-operator_06_clusteroperator.yaml | 13 +++++++++
 pkg/operator/status.go                        | 28 +++++++++++++++++++
 pkg/operator/sync.go                          |  4 +++
 3 files changed, 45 insertions(+)

diff --git a/install/0000_80_machine-config-operator_06_clusteroperator.yaml b/install/0000_80_machine-config-operator_06_clusteroperator.yaml
index 0ca35193f3..c99b885ddb 100644
--- a/install/0000_80_machine-config-operator_06_clusteroperator.yaml
+++ b/install/0000_80_machine-config-operator_06_clusteroperator.yaml
@@ -9,3 +9,16 @@ status:
   versions:
     - name: operator
       version: "0.0.1-snapshot"
+  relatedObjects:
+    - group: ""
+      name: openshift-machine-config-operator
+      resource: namespaces
+    - group: machineconfiguration.openshift.io
+      name: master
+      resource: machineconfigpools
+    - group: machineconfiguration.openshift.io
+      name: worker
+      resource: machineconfigpools
+    - group: machineconfiguration.openshift.io
+      name: machine-config-controller
+      resource: controllerconfigs
diff --git a/pkg/operator/status.go b/pkg/operator/status.go
index 35bdf2f502..6e70435e9e 100644
--- a/pkg/operator/status.go
+++ b/pkg/operator/status.go
@@ -8,6 +8,7 @@ import (
 	configv1 "github.com/openshift/api/config/v1"
 	cov1helpers "github.com/openshift/library-go/pkg/config/clusteroperator/v1helpers"
 	corev1 "k8s.io/api/core/v1"
+	"k8s.io/apimachinery/pkg/api/equality"
 	apierrors "k8s.io/apimachinery/pkg/api/errors"
 	"k8s.io/apimachinery/pkg/api/meta"
 	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
@@ -50,6 +51,33 @@ func (optr *Operator) syncVersion() error {
 	return err
 }
 
+// syncRelatedObjects handles reporting the relatedObjects to the clusteroperator
+func (optr *Operator) syncRelatedObjects() error {
+	co, err := optr.fetchClusterOperator()
+	if err != nil {
+		return err
+	}
+	if co == nil {
+		return nil
+	}
+
+	coCopy := co.DeepCopy()
+	// RelatedObjects are consumed by https://github.com/openshift/must-gather
+	co.Status.RelatedObjects = []configv1.ObjectReference{
+		{Resource: "namespaces", Name: optr.namespace},
+		{Group: "machineconfiguration.openshift.io", Resource: "machineconfigpools", Name: "master"},
+		{Group: "machineconfiguration.openshift.io", Resource: "machineconfigpools", Name: "worker"},
+		{Group: "machineconfiguration.openshift.io", Resource: "controllerconfigs", Name: "machine-config-controller"},
+	}
+
+	if !equality.Semantic.DeepEqual(coCopy.Status.RelatedObjects, co.Status.RelatedObjects) {
+		_, err := optr.configClient.ConfigV1().ClusterOperators().UpdateStatus(co)
+		return err
+	}
+
+	return nil
+}
+
 // syncAvailableStatus applies the new condition to the mco's ClusterOperator object.
 func (optr *Operator) syncAvailableStatus() error {
 	co, err := optr.fetchClusterOperator()
diff --git a/pkg/operator/sync.go b/pkg/operator/sync.go
index 14f2d5b345..918d415a3e 100644
--- a/pkg/operator/sync.go
+++ b/pkg/operator/sync.go
@@ -81,6 +81,10 @@ func (optr *Operator) syncAll(syncFuncs []syncFunc) error {
 		return fmt.Errorf("error syncing version: %v", err)
 	}
 
+	if err := optr.syncRelatedObjects(); err != nil {
+		return fmt.Errorf("error syncing relatedObjects: %v", err)
+	}
+
 	if optr.inClusterBringup && syncErr.err == nil {
 		glog.Infof("Initialization complete")
 		optr.inClusterBringup = false