feat: allow DependentResourceNode creation override (#2961)

Signed-off-by: xstefank <xstefank122@gmail.com>

Author: xstefank

operator-framework-core/src/main/java/io/javaoperatorsdk/operator/api/reconciler/dependent/DependentResourceFactory.java

@@ -4,6 +4,7 @@
 import io.javaoperatorsdk.operator.api.config.Utils;
 import io.javaoperatorsdk.operator.api.config.dependent.DependentResourceSpec;
 import io.javaoperatorsdk.operator.api.reconciler.dependent.managed.ConfiguredDependentResource;
+import io.javaoperatorsdk.operator.processing.dependent.workflow.DependentResourceNode;
 
 @SuppressWarnings({"rawtypes", "unchecked"})
 public interface DependentResourceFactory<
@@ -36,4 +37,13 @@ default Class<?> associatedResourceType(D spec) {
             dependentResourceClass, DependentResource.class, null, null);
     return dr != null ? dr.resourceType() : null;
   }
+
+  default DependentResourceNode createNodeFrom(D spec, DependentResource dependentResource) {
+    return new DependentResourceNode(
+        spec.getReconcileCondition(),
+        spec.getDeletePostCondition(),
+        spec.getReadyCondition(),
+        spec.getActivationCondition(),
+        dependentResource);
+  }
 }

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

@@ -77,12 +77,10 @@ public Workflow<P> resolve(KubernetesClient client, ControllerConfiguration<P> c
     for (DependentResourceSpec<?, P, ?> spec : orderedSpecs) {
       final var dependentResource = resolve(spec, client, configuration);
       final var node =
-          new DependentResourceNode(
-              spec.getReconcileCondition(),
-              spec.getDeletePostCondition(),
-              spec.getReadyCondition(),
-              spec.getActivationCondition(),
-              dependentResource);
+          configuration
+              .getConfigurationService()
+              .dependentResourceFactory()
+              .createNodeFrom(spec, dependentResource);
       alreadyResolved.put(dependentResource.name(), node);
       spec.getDependsOn().forEach(depend -> node.addDependsOnRelation(alreadyResolved.get(depend)));
     }

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

@@ -8,7 +8,7 @@
 import io.javaoperatorsdk.operator.api.reconciler.dependent.DependentResource;
 
 @SuppressWarnings("rawtypes")
-class DependentResourceNode<R, P extends HasMetadata> {
+public class DependentResourceNode<R, P extends HasMetadata> {
 
   private final List<DependentResourceNode> dependsOn = new LinkedList<>();
   private final List<DependentResourceNode> parents = new LinkedList<>();