Before deleting, check if there are other configurations using the same backend. If there are, do not proceed with the deletion

controllers/configuration/configuration.go

@@ -3,6 +3,7 @@
 import (
  "context"
  "fmt"
+ "reflect"
  "strconv"
  "strings"
 
@@ -89,8 +90,8 @@
 // - it's in force-delete state
 func IsDeletable(ctx context.Context, k8sClient client.Client, configuration *v1beta2.Configuration) (bool, error) {
  if feature.DefaultFeatureGate.Enabled(features.AllowDeleteProvisioningResource) {
  return true, nil
  }
  if configuration.Spec.ForceDelete != nil && *configuration.Spec.ForceDelete {
  return true, nil
  }
@@ -159,3 +160,72 @@
  Namespace: provider.DefaultNamespace,
  }
 }
+
+// GetConfigurationsWithSameBackendReference will get configurations referencing the same backend
+func GetConfigurationsWithSameBackendReference(ctx context.Context, k8sClient client.Client, configuration *v1beta2.Configuration) ([]*crossplane.Reference, error) {
+ var (
+ configurationRefs = make([]*crossplane.Reference, 0)
+ selector func(referenceBackend, backend *v1beta2.Backend) bool
+ )
+
+ backend := configuration.Spec.Backend
+ if backend == nil {
+ return configurationRefs, nil
+ }
+
+ switch {
+ case backend.Inline != "":
+ selector = func(referenceBackend, backend *v1beta2.Backend) bool {
+ if backend == nil {
+ return false
+ }
+ return referenceBackend.Inline == backend.Inline
+ }
+ case backend.BackendType == "s3" && backend.S3 != nil:
+ selector = func(referenceBackend, backend *v1beta2.Backend) bool {
+ if backend == nil {
+ return false
+ }
+ return referenceBackend.BackendType == backend.BackendType && reflect.DeepEqual(referenceBackend.S3, backend.S3)
+ }
+ case backend.BackendType == "kubernetes" && backend.Kubernetes != nil:
+ selector = func(referenceBackend, backend *v1beta2.Backend) bool {
+ if backend == nil {
+ return false
+ }
+ return referenceBackend.BackendType == backend.BackendType && reflect.DeepEqual(referenceBackend.Kubernetes, backend.Kubernetes)
+ }
+ case backend.SecretSuffix != "":
+ selector = func(referenceBackend, backend *v1beta2.Backend) bool {
+ if backend == nil {
+ return false
+ }
+ return referenceBackend.SecretSuffix == backend.SecretSuffix
+ }
+ }
+
+ if selector == nil {
+ return configurationRefs, nil
+ }
+
+ configurations := &v1beta2.ConfigurationList{}
+ if err := k8sClient.List(ctx, configurations); err != nil {
+ return configurationRefs, client.IgnoreNotFound(err)
+ }
+
+ for _, item := range configurations.Items {
+ if item.Name == configuration.Name && item.Namespace == configuration.Namespace {
+ continue
+ }
+ // reflect.DeepEqual(backend, item.Spec.Backend) This approach may not yield accurate results.
+ if !selector(backend, item.Spec.Backend) {
+ continue
+ }
+ configurationRefs = append(configurationRefs, &crossplane.Reference{
+ Name: item.Name,
+ Namespace: item.Namespace,
+ })
+ }
+
+ return configurationRefs, nil
+}