Merge pull request #26 from thschue/main

feat: create configmap if manually deleted

Author: thschue

controllers/featureflagconfiguration_controller.go

@@ -22,6 +22,7 @@ import (
 	"github.com/open-feature/open-feature-operator/pkg/utils"
 	corev1 "k8s.io/api/core/v1"
 	"k8s.io/apimachinery/pkg/api/errors"
+	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
 	"k8s.io/client-go/tools/record"
 	"sigs.k8s.io/controller-runtime/pkg/controller/controllerutil"
 	"time"
@@ -109,11 +110,13 @@ func (r *FeatureFlagConfigurationReconciler) Reconcile(ctx context.Context, req
 		return r.finishReconcile(err, false)
 	}
 
+	cmExists := false
 	// Get list of configmaps with annotation
 	for _, cm := range configMapList.Items {
 		val, ok := cm.GetAnnotations()["openfeature.dev/featureflagconfiguration"]
 		if ok && val == ffconf.Name {
 			ffConfigMapList = append(ffConfigMapList, cm)
+			cmExists = true
 		}
 	}
 
@@ -143,6 +146,32 @@ func (r *FeatureFlagConfigurationReconciler) Reconcile(ctx context.Context, req
 		}
 	}
 
+	if !cmExists {
+		ffOwnerRefs := []metav1.OwnerReference{
+			utils.GetFfReference(ffconf),
+		}
+		cm := utils.GenerateFfConfigMap(ffconf.Name, ffconf.Namespace, ffOwnerRefs, ffconf.Spec)
+
+		podList := &corev1.PodList{}
+		if err := r.List(ctx, podList); err != nil {
+			return r.finishReconcile(err, false)
+		}
+		for _, pod := range podList.Items {
+			val, ok := pod.GetAnnotations()["openfeature.dev/featureflagconfiguration"]
+			if ok && val == ffconf.Name {
+				reference := pod.OwnerReferences[0]
+				reference.Controller = utils.FalseVal()
+				cm.OwnerReferences = append(cm.OwnerReferences, reference)
+			}
+		}
+		// Create ConfigMap only if there is a pod which uses it
+		if len(cm.OwnerReferences) > 1 {
+			err := r.Client.Create(ctx, &cm)
+			return r.finishReconcile(err, true)
+		}
+
+	}
+
 	return r.finishReconcile(nil, false)
 }
 

pkg/utils/utils.go

@@ -2,6 +2,7 @@ package utils
 
 import (
 	configv1alpha1 "github.com/open-feature/open-feature-operator/apis/core/v1alpha1"
+	corev1 "k8s.io/api/core/v1"
 	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
 )
 
@@ -33,3 +34,19 @@ func GetFfReference(ff *configv1alpha1.FeatureFlagConfiguration) metav1.OwnerRef
 		Controller: TrueVal(),
 	}
 }
+
+func GenerateFfConfigMap(name string, namespace string, references []metav1.OwnerReference, spec configv1alpha1.FeatureFlagConfigurationSpec) corev1.ConfigMap {
+	return corev1.ConfigMap{
+		ObjectMeta: metav1.ObjectMeta{
+			Name:      name,
+			Namespace: namespace,
+			Annotations: map[string]string{
+				"openfeature.dev/featureflagconfiguration": name,
+			},
+			OwnerReferences: references,
+		},
+		Data: map[string]string{
+			"config.yaml": spec.FeatureFlagSpec,
+		},
+	}
+}

webhooks/mutating_admission_webhook.go

@@ -114,19 +114,8 @@ func (m *PodMutator) createConfigMap(ctx context.Context, name string, namespace
 		references = append(references, utils.GetFfReference(&ff))
 	}
 
-	cm := corev1.ConfigMap{
-		ObjectMeta: metav1.ObjectMeta{
-			Name:      name,
-			Namespace: namespace,
-			Annotations: map[string]string{
-				"openfeature.dev/featureflagconfiguration": name,
-			},
-			OwnerReferences: references,
-		},
-		Data: map[string]string{
-			"config.yaml": ff.Spec.FeatureFlagSpec,
-		},
-	}
+	cm := utils.GenerateFfConfigMap(name, namespace, references, ff.Spec)
+
 	return m.Client.Create(ctx, &cm)
 }