udpate configmap (#37)

Signed-off-by: Kim Tsao <[email protected]>

Author: kim-tsao

controllers/devfileregistry_controller.go

@@ -1,5 +1,5 @@
 /*
-Copyright 2020-2022 Red Hat, Inc.
+Copyright 2020-2023 Red Hat, Inc.
 
 Licensed under the Apache License, Version 2.0 (the "License");
 you may not use this file except in compliance with the License.
@@ -162,6 +162,13 @@ func (r *DevfileRegistryReconciler) Reconcile(ctx context.Context, req ctrl.Requ
 			log.Error(err, "Failed to update DevfileRegistry status")
 			return ctrl.Result{Requeue: true}, err
 		}
+
+		//update the config map
+		result, err = r.ensure(ctx, devfileRegistry, &corev1.ConfigMap{}, labels, "")
+		if result != nil {
+			return *result, err
+		}
+
 	}
 
 	return ctrl.Result{}, nil
@@ -180,7 +187,8 @@ func (r *DevfileRegistryReconciler) SetupWithManager(mgr ctrl.Manager) error {
 		Owns(&appsv1.Deployment{}).
 		Owns(&corev1.Service{}).
 		Owns(&corev1.PersistentVolumeClaim{}).
-		Owns(&networkingv1.Ingress{})
+		Owns(&networkingv1.Ingress{}).
+		Owns(&corev1.ConfigMap{})
 
 	// If on OpenShift, mark routes as owned by the controller
 	if config.ControllerCfg.IsOpenShift() {

controllers/ensure.go

@@ -66,6 +66,9 @@ func (r *DevfileRegistryReconciler) ensure(ctx context.Context, cr *registryv1al
 	case *networkingv1.Ingress:
 		ingress, _ := resource.(*networkingv1.Ingress)
 		err = r.updateIngress(ctx, cr, ingressDomain, ingress)
+	case *corev1.ConfigMap:
+		configMap, _ := resource.(*corev1.ConfigMap)
+		err = r.updateConfigMap(ctx, cr, configMap)
 	}
 	if err != nil {
 		r.Log.Error(err, "Failed to update "+resourceType)

controllers/update.go

@@ -18,6 +18,7 @@ package controllers
 
 import (
 	"context"
+	"fmt"
 
 	registryv1alpha1 "github.com/devfile/registry-operator/api/v1alpha1"
 	"github.com/devfile/registry-operator/pkg/registry"
@@ -182,3 +183,16 @@ func (r *DevfileRegistryReconciler) deleteOldPVCIfNeeded(ctx context.Context, cr
 	}
 	return nil
 }
+
+func (r *DevfileRegistryReconciler) updateConfigMap(ctx context.Context, cr *registryv1alpha1.DevfileRegistry, configMap *corev1.ConfigMap) error {
+
+	viewerEnvfile := fmt.Sprintf(`
+NEXT_PUBLIC_ANALYTICS_WRITE_KEY=%s
+DEVFILE_REGISTRIES=[{"name":"%s","url":"http://localhost:8080","fqdn":"%s"}]`,
+		cr.Spec.Telemetry.RegistryViewerWriteKey, cr.ObjectMeta.Name, cr.Status.URL)
+
+	configMap.Data[".env.registry-viewer"] = viewerEnvfile
+
+	return r.Update(ctx, configMap)
+
+}