feat: condition for bulk resources

Author: csviri

operator-framework/src/test/java/io/javaoperatorsdk/operator/bulkdependent/BulkDependentWithPreconditionIT.java

@@ -0,0 +1,39 @@
+package io.javaoperatorsdk.operator.bulkdependent;
+
+import org.junit.jupiter.api.Test;
+import org.junit.jupiter.api.extension.RegisterExtension;
+
+import io.javaoperatorsdk.operator.junit.LocallyRunOperatorExtension;
+import io.javaoperatorsdk.operator.sample.bulkdependent.ManagedBulkDependentWithPreconditionReconciler;
+
+import static io.javaoperatorsdk.operator.bulkdependent.BulkDependentTestBase.INITIAL_NUMBER_OF_CONFIG_MAPS;
+import static io.javaoperatorsdk.operator.bulkdependent.BulkDependentTestBase.testResource;
+import static io.javaoperatorsdk.operator.sample.bulkdependent.ConfigMapDeleterBulkDependentResource.LABEL_KEY;
+import static io.javaoperatorsdk.operator.sample.bulkdependent.ConfigMapDeleterBulkDependentResource.LABEL_VALUE;
+import static org.assertj.core.api.Assertions.*;
+import static org.awaitility.Awaitility.await;
+
+class BulkDependentWithPreconditionIT {
+
+  @RegisterExtension
+  LocallyRunOperatorExtension extension =
+      LocallyRunOperatorExtension.builder()
+          .withReconciler(new ManagedBulkDependentWithPreconditionReconciler())
+          .build();
+
+  @Test
+  void handlesBulkDependentWithPrecondition() {
+    var resource = testResource();
+    extension.create(resource);
+
+    await().untilAsserted(() -> {
+      var cms = extension.getKubernetesClient().configMaps().inNamespace(extension.getNamespace())
+          .withLabel(LABEL_KEY, LABEL_VALUE)
+          .list().getItems();
+      assertThat(cms).hasSize(INITIAL_NUMBER_OF_CONFIG_MAPS);
+    });
+  }
+
+
+
+}

operator-framework/src/test/java/io/javaoperatorsdk/operator/sample/bulkdependent/ManagedBulkDependentWithPreconditionReconciler.java

@@ -0,0 +1,29 @@
+package io.javaoperatorsdk.operator.sample.bulkdependent;
+
+import java.util.concurrent.atomic.AtomicInteger;
+
+import io.javaoperatorsdk.operator.api.reconciler.Context;
+import io.javaoperatorsdk.operator.api.reconciler.ControllerConfiguration;
+import io.javaoperatorsdk.operator.api.reconciler.Reconciler;
+import io.javaoperatorsdk.operator.api.reconciler.UpdateControl;
+import io.javaoperatorsdk.operator.api.reconciler.dependent.Dependent;
+
+@ControllerConfiguration(dependents = @Dependent(reconcilePrecondition = SamplePrecondition.class,
+    type = CRUDConfigMapBulkDependentResource.class))
+public class ManagedBulkDependentWithPreconditionReconciler
+    implements Reconciler<BulkDependentTestCustomResource> {
+
+  private final AtomicInteger numberOfExecutions = new AtomicInteger(0);
+
+  @Override
+  public UpdateControl<BulkDependentTestCustomResource> reconcile(
+      BulkDependentTestCustomResource resource,
+      Context<BulkDependentTestCustomResource> context) throws Exception {
+    numberOfExecutions.incrementAndGet();
+    return UpdateControl.noUpdate();
+  }
+
+  public int getNumberOfExecutions() {
+    return numberOfExecutions.get();
+  }
+}

operator-framework/src/test/java/io/javaoperatorsdk/operator/sample/bulkdependent/SamplePrecondition.java

@@ -0,0 +1,16 @@
+package io.javaoperatorsdk.operator.sample.bulkdependent;
+
+import io.fabric8.kubernetes.api.model.ConfigMap;
+import io.javaoperatorsdk.operator.api.reconciler.Context;
+import io.javaoperatorsdk.operator.processing.dependent.workflow.Condition;
+
+public class SamplePrecondition implements Condition<ConfigMap, BulkDependentTestCustomResource> {
+
+  public static final String SKIP_RESOURCE_DATA = "skipThis";
+
+  @Override
+  public boolean isMet(BulkDependentTestCustomResource primary, ConfigMap secondary,
+      Context<BulkDependentTestCustomResource> context) {
+    return !SKIP_RESOURCE_DATA.equals(primary.getSpec().getAdditionalData());
+  }
+}