revert the host back to default value

Signed-off-by: YuChen <[email protected]>

Author: YuChen

controllers/operandrequest/reconcile_operand.go

@@ -948,16 +948,48 @@ func (r *Reconciler) createK8sResource(ctx context.Context, k8sResTemplate unstr
 	name := k8sResTemplate.GetName()
 	namespace := k8sResTemplate.GetNamespace()
 
+	if kind == "Route" {
+		host, _, err := unstructured.NestedString(k8sResTemplate.Object, "spec", "host")
+		klog.Info("11111 host %v: ", host)
+
+		if err != nil {
+			klog.Errorf("failed to get spec.host for Route: %v", err)
+			return err
+		}
+
+		// Calculate and set hash for spec.host
+		hostHash := util.CalculateHash(host)
+		if newAnnotations == nil {
+			newAnnotations = make(map[string]string)
+		}
+		newAnnotations["openshift.io/keycloak-host.hashedData"] = hostHash
+		// klog.Infof("22222 Set host hash annotation: %s", hostHash)
+	}
+
 	if k8sResConfig != nil {
 		k8sResConfigDecoded := make(map[string]interface{})
 		k8sResConfigUnmarshalErr := json.Unmarshal(k8sResConfig.Raw, &k8sResConfigDecoded)
 		if k8sResConfigUnmarshalErr != nil {
 			klog.Errorf("failed to unmarshal k8s Resource Config: %v", k8sResConfigUnmarshalErr)
 		}
-
+		klog.Infof("11111 k8sResConfig: %v", k8sResConfigDecoded)
 		for k, v := range k8sResConfigDecoded {
 			k8sResTemplate.Object[k] = v
 		}
+
+		if kind == "Route" {
+			if host, found := k8sResConfigDecoded["spec"].(map[string]interface{})["host"].(string); found {
+				hostHash := util.CalculateHash(host)
+
+				if newAnnotations == nil {
+					newAnnotations = make(map[string]string)
+				}
+				newAnnotations["openshift.io/keycloak-host.hashedData"] = hostHash
+				klog.Infof(" 2222  Route spec.host: %s, calculated host-hash: %s", host, hostHash)
+			} else {
+				klog.Warningf("spec.host not found in k8sResConfig for Route")
+			}
+		}
 	}
 
 	r.EnsureLabel(k8sResTemplate, map[string]string{constant.OpreqLabel: "true"})
@@ -983,6 +1015,7 @@ func (r *Reconciler) updateK8sResource(ctx context.Context, existingK8sRes unstr
 	apiversion := existingK8sRes.GetAPIVersion()
 	name := existingK8sRes.GetName()
 	namespace := existingK8sRes.GetNamespace()
+
 	if kind == "Job" {
 		existingK8sRes := unstructured.Unstructured{
 			Object: map[string]interface{}{
@@ -1038,6 +1071,63 @@ func (r *Reconciler) updateK8sResource(ctx context.Context, existingK8sRes unstr
 		return nil
 	}
 
+	if kind == "Route" {
+		existingAnnos := existingK8sRes.GetAnnotations()
+		existingHostHash := existingAnnos["openshift.io/keycloak-host.hashedData"]
+		klog.Infof("111--11 existing host hash: %s", existingHostHash)
+
+		if k8sResConfig != nil {
+			k8sResConfigDecoded := make(map[string]interface{})
+			k8sResConfigUnmarshalErr := json.Unmarshal(k8sResConfig.Raw, &k8sResConfigDecoded)
+			if k8sResConfigUnmarshalErr != nil {
+				klog.Errorf("failed to unmarshal k8s Resource Config: %v", k8sResConfigUnmarshalErr)
+			}
+			klog.Infof("111--11 k8sResConfig: %v", k8sResConfigDecoded)
+
+			// Read the host from the OperandConfig
+			if newHost, found := k8sResConfigDecoded["spec"].(map[string]interface{})["host"].(string); found {
+				newHostHash := util.CalculateHash(newHost)
+
+				klog.Infof("3333 new host hash: %s", newHostHash)
+
+				// Only re-create the route if the custom host has been removed
+				if newHost == "" && existingHostHash != newHostHash {
+					klog.Infof("4444 Custom host removed or changed, resetting to default value")
+
+					// create a new template of k8s resource
+					var templatek8sRes unstructured.Unstructured
+					templatek8sRes.SetAPIVersion(apiversion)
+					templatek8sRes.SetKind(kind)
+					templatek8sRes.SetName(name)
+					templatek8sRes.SetNamespace(namespace)
+
+					if err := r.deleteK8sResource(ctx, existingK8sRes, namespace); err != nil {
+						return errors.Wrap(err, "failed to delete Route for recreation")
+					}
+					if err := r.createK8sResource(ctx, templatek8sRes, k8sResConfig, newLabels, newAnnotations, ownerReferences); err != nil {
+						return errors.Wrap(err, "failed to update k8s resource")
+					}
+					return nil
+				}
+
+				// Only update the resource if the host has changed
+				if existingHostHash != newHostHash {
+					klog.Infof("5555 Custom host changed, updating Route with new host hash")
+
+					existingAnnos["openshift.io/keycloak-host.hashedData"] = newHostHash
+					r.EnsureAnnotation(existingK8sRes, existingAnnos)
+				}
+				// Update resource in the cluster
+				if err := r.Update(ctx, &existingK8sRes); err != nil {
+					return errors.Wrap(err, "failed to update Route resource with new host hash")
+				}
+				klog.Infof("Updated Route with new host hash: %s", newHostHash)
+
+			}
+		}
+		return nil
+	}
+
 	// Update the k8s res
 	err := wait.PollImmediate(constant.DefaultCRFetchPeriod, constant.DefaultCRFetchTimeout, func() (bool, error) {
 

controllers/util/util.go

@@ -18,6 +18,8 @@ package util
 
 import (
 	"bytes"
+	"crypto/sha256"
+	"encoding/hex"
 	"fmt"
 	"os"
 	"sort"
@@ -150,6 +152,14 @@ func StringSliceContentEqual(a, b []string) bool {
 	return true
 }
 
+func CalculateHash(input string) string {
+	if input == "" {
+		return ""
+	}
+	hashedData := sha256.Sum256([]byte(input))
+	return hex.EncodeToString(hashedData[:7])
+}
+
 // WaitTimeout waits for the waitgroup for the specified max timeout.
 // Returns true if waiting timed out.
 func WaitTimeout(wg *sync.WaitGroup, timeout time.Duration) bool {