[WIP] feat: external id provider for external dependent resources

Signed-off-by: Attila Mészáros <[email protected]>

Author: csviri

operator-framework-core/src/main/java/io/javaoperatorsdk/operator/processing/dependent/AbstractExternalDependentResource.java

@@ -1,5 +1,9 @@
 package io.javaoperatorsdk.operator.processing.dependent;
 
+import java.util.List;
+import java.util.Optional;
+import java.util.Set;
+
 import io.fabric8.kubernetes.api.model.HasMetadata;
 import io.javaoperatorsdk.operator.api.reconciler.Context;
 import io.javaoperatorsdk.operator.api.reconciler.dependent.RecentOperationCacheFiller;
@@ -106,4 +110,24 @@ public void handleDeleteTargetResource(P primary, R resource, String key, Contex
   protected InformerEventSource getExternalStateEventSource() {
     return externalStateEventSource;
   }
+
+  @Override
+  protected Optional<R> selectTargetSecondaryResource(
+      Set<R> secondaryResources, P primary, Context<P> context) {
+    R desired = desired(primary, context);
+    List<R> targetResources;
+    if (desired instanceof ExternalDependentIDProvider<?> desiredWithId) {
+      targetResources =
+          secondaryResources.stream()
+              .filter(r -> ((ExternalDependentIDProvider<?>) r).id().equals(desiredWithId.id()))
+              .toList();
+    } else {
+      targetResources = secondaryResources.stream().filter(r -> r.equals(desired)).toList();
+    }
+    if (targetResources.size() > 1) {
+      throw new IllegalStateException(
+          "More than one secondary resource related to primary: " + targetResources);
+    }
+    return targetResources.isEmpty() ? Optional.empty() : Optional.of(targetResources.get(0));
+  }
 }

operator-framework-core/src/main/java/io/javaoperatorsdk/operator/processing/dependent/ExternalDependentIDProvider.java

@@ -0,0 +1,6 @@
+package io.javaoperatorsdk.operator.processing.dependent;
+
+public interface ExternalDependentIDProvider<T> {
+
+  T id();
+}

sample-operators/mysql-schema/src/main/java/io/javaoperatorsdk/operator/sample/schema/Schema.java

@@ -3,7 +3,9 @@
 import java.io.Serializable;
 import java.util.Objects;
 
-public class Schema implements Serializable {
+import io.javaoperatorsdk.operator.processing.dependent.ExternalDependentIDProvider;
+
+public class Schema implements Serializable, ExternalDependentIDProvider<String> {
 
   private final String name;
   private final String characterSet;
@@ -38,4 +40,9 @@ public int hashCode() {
   public String toString() {
     return "Schema{" + "name='" + name + '\'' + ", characterSet='" + characterSet + '\'' + '}';
   }
+
+  @Override
+  public String id() {
+    return name;
+  }
 }