progress

Signed-off-by: Attila Mészáros <csviri@gmail.com>

Author: csviri

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

@@ -76,6 +76,7 @@ public class Controller<P extends HasMetadata>
   private final GroupVersionKind associatedGVK;
   private final EventProcessor<P> eventProcessor;
   private final ControllerHealthInfo controllerHealthInfo;
+  private final EventSourceContext<P> eventSourceContext;
 
   public Controller(Reconciler<P> reconciler,
       ControllerConfiguration<P> configuration,
@@ -98,9 +99,9 @@ public Controller(Reconciler<P> reconciler,
     eventProcessor = new EventProcessor<>(eventSourceManager, configurationService);
     eventSourceManager.postProcessDefaultEventSourcesAfterProcessorInitializer();
     controllerHealthInfo = new ControllerHealthInfo(eventSourceManager);
-    final var context = new EventSourceContext<>(
+    eventSourceContext = new EventSourceContext<>(
         eventSourceManager.getControllerResourceEventSource(), configuration, kubernetesClient);
-    initAndRegisterEventSources(context);
+    initAndRegisterEventSources(eventSourceContext);
     configurationService.getMetrics().controllerRegistered(this);
   }
 
@@ -440,4 +441,8 @@ public EventProcessor<P> getEventProcessor() {
   public ExecutorServiceManager getExecutorServiceManager() {
     return getConfiguration().getConfigurationService().getExecutorServiceManager();
   }
+
+  public EventSourceContext<P> eventSourceContext() {
+    return eventSourceContext;
+  }
 }

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

@@ -64,13 +64,38 @@ private synchronized <R> void handleReconcile(DependentResourceNode<R, P> depend
 
     boolean reconcileConditionMet = isConditionMet(dependentResourceNode.getReconcilePrecondition(),
         dependentResourceNode.getDependentResource());
-    if (!reconcileConditionMet) {
+    boolean activationConditionMet = isConditionMet(dependentResourceNode.getActivationCondition(),
+        dependentResourceNode.getDependentResource());
+
+    registerEventSourceForActivationCondition(activationConditionMet, dependentResourceNode);
+
+    if (!reconcileConditionMet || !activationConditionMet) {
       handleReconcileConditionNotMet(dependentResourceNode);
     } else {
       submit(dependentResourceNode, new NodeReconcileExecutor<>(dependentResourceNode), RECONCILE);
     }
   }
 
+  private <R> void registerEventSourceForActivationCondition(boolean activationConditionMet,
+      DependentResourceNode<R, P> dependentResourceNode) {
+    if (dependentResourceNode.getActivationCondition().isPresent()) {
+      if (activationConditionMet) {
+        // todo create issue for v5 to return name also from DependentResource.eventSource
+        var eventSource =
+            dependentResourceNode.getDependentResource().eventSource(context.eventSourceRetriever()
+                .eventSourceContexForDynamicRegistration());
+
+        eventSource.ifPresent(es -> {
+          // todo check if event source with the name not exists yet, if does do not register.
+          context.eventSourceRetriever()
+              .dynamicallyRegisterEventSource(dependentResourceNode.getName(), es);
+        });
+      } else {
+        // todo deregister event source
+      }
+    }
+  }
+
   private synchronized void handleDelete(DependentResourceNode dependentResourceNode) {
     log.debug("Submitting for delete: {}", dependentResourceNode);
 

operator-framework-core/src/main/java/io/javaoperatorsdk/operator/processing/event/EventSourceManager.java

@@ -17,6 +17,7 @@
 import io.javaoperatorsdk.operator.OperatorException;
 import io.javaoperatorsdk.operator.api.config.ExecutorServiceManager;
 import io.javaoperatorsdk.operator.api.config.NamespaceChangeable;
+import io.javaoperatorsdk.operator.api.reconciler.EventSourceContext;
 import io.javaoperatorsdk.operator.api.reconciler.EventSourceInitializer;
 import io.javaoperatorsdk.operator.processing.Controller;
 import io.javaoperatorsdk.operator.processing.LifecycleAware;
@@ -242,6 +243,11 @@ public void dynamicallyDeRegisterEventSource(String name) {
     // todo
   }
 
+  @Override
+  public EventSourceContext<P> eventSourceContexForDynamicRegistration() {
+    return controller.eventSourceContext();
+  }
+
   /**
    * @deprecated Use {@link #getResourceEventSourceFor(Class)} instead
    *

operator-framework-core/src/main/java/io/javaoperatorsdk/operator/processing/event/EventSourceRetriever.java

@@ -3,6 +3,7 @@
 import java.util.List;
 
 import io.fabric8.kubernetes.api.model.HasMetadata;
+import io.javaoperatorsdk.operator.api.reconciler.EventSourceContext;
 import io.javaoperatorsdk.operator.processing.event.source.EventSource;
 import io.javaoperatorsdk.operator.processing.event.source.ResourceEventSource;
 
@@ -21,4 +22,7 @@ default <R> ResourceEventSource<R, P> getResourceEventSourceFor(Class<R> depende
   void dynamicallyRegisterEventSource(String name, EventSource eventSource);
 
   void dynamicallyDeRegisterEventSource(String name);
+
+  EventSourceContext<P> eventSourceContexForDynamicRegistration();
+
 }