feat(olm): write operator status by default

`writeStatusName` may be passed as an argument set to the name in which to write
the status. The default is `openshift-operator-lifecycle-manager` with an empty
string disabling the behavior.

If the proper openshift API group isn't found, the status update will be
skipped.

Author: Jeff Peeler

Diff for: Documentation/install/local-values.yaml

@@ -1,5 +1,6 @@
 rbacApiVersion: rbac.authorization.k8s.io
 namespace: local
+writeStatusName: '""'
 catalog_namespace: local
 operator_namespace: local-operators
 debug: true

Diff for: cmd/olm/main.go

@@ -11,18 +11,27 @@ import (
 	"github.com/prometheus/client_golang/prometheus/promhttp"
 	log "github.com/sirupsen/logrus"
 	v1 "k8s.io/api/core/v1"
-
+	k8serrors "k8s.io/apimachinery/pkg/api/errors"
+	"k8s.io/apimachinery/pkg/api/meta"
+	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
+
+	configv1 "github.com/openshift/api/config/v1"
+	configv1client "github.com/openshift/client-go/config/clientset/versioned/typed/config/v1"
+	clusteroperatorv1helpers "github.com/openshift/library-go/pkg/config/clusteroperator/v1helpers"
+	operatorv1helpers "github.com/openshift/library-go/pkg/operator/v1helpers"
 	"github.com/operator-framework/operator-lifecycle-manager/pkg/api/client"
 	"github.com/operator-framework/operator-lifecycle-manager/pkg/controller/install"
 	"github.com/operator-framework/operator-lifecycle-manager/pkg/controller/operators/olm"
 	"github.com/operator-framework/operator-lifecycle-manager/pkg/lib/operatorclient"
 	"github.com/operator-framework/operator-lifecycle-manager/pkg/lib/signals"
 	"github.com/operator-framework/operator-lifecycle-manager/pkg/metrics"
 	olmversion "github.com/operator-framework/operator-lifecycle-manager/pkg/version"
+	"k8s.io/client-go/tools/clientcmd"
 )
 
 const (
 	defaultWakeupInterval = 5 * time.Minute
+	defaultOperatorName   = "openshift-operator-lifecycle-manager"
 )
 
 // config flags defined globally so that they appear on the test binary as well
@@ -38,6 +47,9 @@ var (
 			"If not set, or set to the empty string (e.g. `-watchedNamespaces=\"\"`), "+
 			"olm operator will watch all namespaces in the cluster.")
 
+	writeStatusName = flag.String(
+		"writeStatusName", defaultOperatorName, "ClusterOperator name in which to write status, set to \"\" to disable.")
+
 	debug = flag.Bool(
 		"debug", false, "use debug log level")
 
@@ -89,6 +101,16 @@ func main() {
 
 	opClient := operatorclient.NewClientFromConfig(*kubeConfigPath, logger)
 
+	// create a config client for operator status
+	config, err := clientcmd.BuildConfigFromFlags("", *kubeConfigPath)
+	if err != nil {
+		log.Fatalf("error configuring client: %s", err.Error())
+	}
+	configClient, err := configv1client.NewForConfig(config)
+	if err != nil {
+		log.Fatalf("error configuring client: %s", err.Error())
+	}
+
 	// Create a new instance of the operator.
 	operator, err := olm.NewOperator(logger, crClient, opClient, &install.StrategyResolver{}, *wakeupInterval, namespaces)
 
@@ -105,6 +127,67 @@ func main() {
 	http.Handle("/metrics", promhttp.Handler())
 	go http.ListenAndServe(":8081", nil)
 
-	_, done := operator.Run(stopCh)
+	ready, done := operator.Run(stopCh)
+	<-ready
+
+	if *writeStatusName != "" {
+		existing, err := configClient.ClusterOperators().Get(*writeStatusName, metav1.GetOptions{})
+		if meta.IsNoMatchError(err) {
+			log.Infof("ClusterOperator api not present, skipping update")
+		} else if k8serrors.IsNotFound(err) {
+			log.Info("Existing cluster operator not found, creating")
+			created, err := configClient.ClusterOperators().Create(&configv1.ClusterOperator{
+				ObjectMeta: metav1.ObjectMeta{
+					Name: *writeStatusName,
+				},
+			})
+			if err != nil {
+				log.Fatalf("ClusterOperator create failed: %v\n", err)
+			}
+
+			created.Status = configv1.ClusterOperatorStatus{
+				Conditions: []configv1.ClusterOperatorStatusCondition{
+					configv1.ClusterOperatorStatusCondition{
+						Type:               configv1.OperatorAvailable,
+						Status:             configv1.ConditionTrue,
+						Message:            fmt.Sprintf("Done deploying %s.", olmversion.OLMVersion),
+						LastTransitionTime: metav1.Now(),
+					},
+				},
+				Versions: []configv1.OperandVersion{{
+					Name:    "operator",
+					Version: olmversion.Full(),
+				}},
+			}
+			_, err = configClient.ClusterOperators().UpdateStatus(created)
+			if err != nil {
+				log.Fatalf("ClusterOperator update status failed: %v", err)
+			}
+		} else if err != nil {
+			log.Fatalf("ClusterOperators get failed: %v", err)
+		} else {
+			clusteroperatorv1helpers.SetStatusCondition(&existing.Status.Conditions, configv1.ClusterOperatorStatusCondition{
+				Type:               configv1.OperatorAvailable,
+				Status:             configv1.ConditionTrue,
+				Message:            fmt.Sprintf("Done deploying %s.", olmversion.OLMVersion),
+				LastTransitionTime: metav1.Now(),
+			})
+			olmOperandVersion := configv1.OperandVersion{Name: "operator", Version: olmversion.Full()}
+			// look for operator version, even though in OLM's case should only be one
+			for _, item := range existing.Status.Versions {
+				if item.Name == "operator" && item != olmOperandVersion {
+					// if a cluster wide upgrade has occurred, hopefully any existing operator statuses have been deleted
+					log.Infof("Updating version from %v to %v\n", item.Version, olmversion.Full())
+				}
+			}
+			operatorv1helpers.SetOperandVersion(&existing.Status.Versions, olmOperandVersion)
+			_, err = configClient.ClusterOperators().UpdateStatus(existing)
+			if err != nil {
+				log.Fatalf("ClusterOperator update status failed: %v", err)
+			}
+		}
+	}
+
 	<-done
 }
+

Diff for: deploy/chart/templates/0000_50_10-olm-operator.deployment.yaml

@@ -33,6 +33,10 @@ spec:
           {{- if .Values.debug }}
           - -debug
           {{- end }}
+          {{- if .Values.writeStatusName }}
+          - -writeStatusName
+          - {{ .Values.writeStatusName }}
+          {{- end }}
           image: {{ .Values.olm.image.ref }}
           imagePullPolicy: {{ .Values.olm.image.pullPolicy }}
           ports:

Diff for: deploy/chart/values.yaml

@@ -2,7 +2,11 @@ rbacApiVersion: rbac.authorization.k8s.io
 namespace: operator-lifecycle-manager
 catalog_namespace: operator-lifecycle-manager
 operator_namespace: operators
+<<<<<<< HEAD
 minKubeVersion: 1.11.0
+=======
+writeStatusName: '""'
+>>>>>>> feat(olm): write operator status by default
 imagestream: false
 debug: false
 olm:

Diff for: deploy/upstream/values.yaml

@@ -3,6 +3,7 @@ namespace: olm
 catalog_namespace: olm
 operator_namespace: operators
 imagestream: false
+writeStatusName: '""'
 olm:
   replicaCount: 1
   image:

Diff for: manifests/0000_30_20-operatorstatus.yaml

@@ -0,0 +1,5 @@
+apiVersion: config.openshift.io/v1
+kind: ClusterOperator
+metadata:
+  namespace: openshift-operator-lifecycle-manager
+  name: openshift-operator-lifecycle-manager

Diff for: pkg/version/version.go

@@ -12,3 +12,8 @@ var GitCommit string
 func String() string {
 	return fmt.Sprintf("OLM version: %s\ngit commit: %s\n", OLMVersion, GitCommit)
 }
+
+// Full returns a hypenated concatenation of just OLMVersion and GitCommit
+func Full() string {
+	return fmt.Sprintf("%s-%s", OLMVersion, GitCommit)
+}

Diff for: test/e2e/e2e-bare-values.yaml

@@ -1,6 +1,7 @@
 rbacApiVersion: rbac.authorization.k8s.io
 namespace: operator-lifecycle-manager
 catalog_namespace: operator-lifecycle-manager
+writeStatusName: '""'
 olm:
   replicaCount: 1
   image:

Diff for: test/e2e/e2e-values.yaml

@@ -1,3 +1,5 @@
+writeStatusName: '""'
+
 olm:
   replicaCount: 1
   image: