Multiple dependent resource integration test

operator-framework/src/test/java/io/javaoperatorsdk/operator/MultipleDependentResourceIT.java

@@ -0,0 +1,61 @@
+package io.javaoperatorsdk.operator;
+
+import java.time.Duration;
+import java.util.stream.IntStream;
+
+import org.junit.jupiter.api.Test;
+import org.junit.jupiter.api.extension.RegisterExtension;
+
+import io.fabric8.kubernetes.api.model.ConfigMap;
+import io.fabric8.kubernetes.api.model.ObjectMetaBuilder;
+import io.javaoperatorsdk.operator.junit.LocalOperatorExtension;
+import io.javaoperatorsdk.operator.sample.multipledependentresource.MultipleDependentResourceConfigMap;
+import io.javaoperatorsdk.operator.sample.multipledependentresource.MultipleDependentResourceCustomResource;
+import io.javaoperatorsdk.operator.sample.multipledependentresource.MultipleDependentResourceReconciler;
+
+import static org.assertj.core.api.Assertions.assertThat;
+import static org.awaitility.Awaitility.await;
+
+class MultipleDependentResourceIT {
+
+  public static final String TEST_RESOURCE_NAME = "multipledependentresource-testresource";
+  @RegisterExtension
+  LocalOperatorExtension operator =
+      LocalOperatorExtension.builder().withReconciler(MultipleDependentResourceReconciler.class)
+          .waitForNamespaceDeletion(true)
+          .build();
+
+  @Test
+  void twoConfigMapsHaveBeenCreated() {
+    MultipleDependentResourceCustomResource customResource = createTestCustomResource();
+    operator.create(MultipleDependentResourceCustomResource.class, customResource);
+
+    var reconciler = operator.getReconcilerOfType(MultipleDependentResourceReconciler.class);
+
+    await().pollDelay(Duration.ofMillis(300))
+        .until(() -> reconciler.getNumberOfExecutions() <= 1);
+
+    IntStream.of(MultipleDependentResourceReconciler.FIRST_CONFIG_MAP_ID,
+        MultipleDependentResourceReconciler.SECOND_CONFIG_MAP_ID).forEach(configMapId -> {
+          ConfigMap configMap =
+              operator.get(ConfigMap.class, customResource.getConfigMapName(configMapId));
+          assertThat(configMap).isNotNull();
+          assertThat(configMap.getMetadata().getName())
+              .isEqualTo(customResource.getConfigMapName(configMapId));
+          assertThat(configMap.getData().get(MultipleDependentResourceConfigMap.DATA_KEY))
+              .isEqualTo(String.valueOf(configMapId));
+        });
+  }
+
+  public MultipleDependentResourceCustomResource createTestCustomResource() {
+    MultipleDependentResourceCustomResource resource =
+        new MultipleDependentResourceCustomResource();
+    resource.setMetadata(
+        new ObjectMetaBuilder()
+            .withName(TEST_RESOURCE_NAME)
+            .withNamespace(operator.getNamespace())
+            .build());
+    return resource;
+  }
+
+}

operator-framework/src/test/java/io/javaoperatorsdk/operator/sample/multipledependentresource/MultipleDependentResourceConfigMap.java

@@ -0,0 +1,39 @@
+package io.javaoperatorsdk.operator.sample.multipledependentresource;
+
+import java.util.HashMap;
+import java.util.Map;
+
+import io.fabric8.kubernetes.api.model.ConfigMap;
+import io.fabric8.kubernetes.api.model.ConfigMapBuilder;
+import io.javaoperatorsdk.operator.api.reconciler.Context;
+import io.javaoperatorsdk.operator.processing.dependent.kubernetes.CRUKubernetesDependentResource;
+import io.javaoperatorsdk.operator.processing.dependent.kubernetes.KubernetesDependent;
+
+@KubernetesDependent
+public class MultipleDependentResourceConfigMap
+    extends CRUKubernetesDependentResource<ConfigMap, MultipleDependentResourceCustomResource> {
+
+  public static final String DATA_KEY = "key";
+  private final int value;
+
+  public MultipleDependentResourceConfigMap(int value) {
+    super(ConfigMap.class);
+    this.value = value;
+  }
+
+  @Override
+  protected ConfigMap desired(MultipleDependentResourceCustomResource primary,
+      Context<MultipleDependentResourceCustomResource> context) {
+    Map<String, String> data = new HashMap<>();
+    data.put(DATA_KEY, String.valueOf(value));
+
+    return new ConfigMapBuilder()
+        .withNewMetadata()
+        .withName(primary.getConfigMapName(value))
+        .withNamespace(primary.getMetadata().getNamespace())
+        .withLabels(Map.of(MultipleDependentResourceReconciler.LABEL, String.valueOf(value)))
+        .endMetadata()
+        .withData(data)
+        .build();
+  }
+}

operator-framework/src/test/java/io/javaoperatorsdk/operator/sample/multipledependentresource/MultipleDependentResourceCustomResource.java

@@ -0,0 +1,21 @@
+package io.javaoperatorsdk.operator.sample.multipledependentresource;
+
+import io.fabric8.kubernetes.api.model.Namespaced;
+import io.fabric8.kubernetes.client.CustomResource;
+import io.fabric8.kubernetes.model.annotation.Group;
+import io.fabric8.kubernetes.model.annotation.Kind;
+import io.fabric8.kubernetes.model.annotation.ShortNames;
+import io.fabric8.kubernetes.model.annotation.Version;
+
+@Group("sample.javaoperatorsdk")
+@Version("v1")
+@Kind("MultipleDependentResourceCustomResource")
+@ShortNames("mdr")
+public class MultipleDependentResourceCustomResource
+    extends CustomResource<Void, MultipleDependentResourceStatus>
+    implements Namespaced {
+
+  public String getConfigMapName(int id) {
+    return "configmap" + id;
+  }
+}

operator-framework/src/test/java/io/javaoperatorsdk/operator/sample/multipledependentresource/MultipleDependentResourceReconciler.java

@@ -0,0 +1,83 @@
+package io.javaoperatorsdk.operator.sample.multipledependentresource;
+
+import java.util.Map;
+import java.util.concurrent.atomic.AtomicInteger;
+
+import io.fabric8.kubernetes.client.KubernetesClient;
+import io.javaoperatorsdk.operator.api.reconciler.Context;
+import io.javaoperatorsdk.operator.api.reconciler.ControllerConfiguration;
+import io.javaoperatorsdk.operator.api.reconciler.EventSourceContext;
+import io.javaoperatorsdk.operator.api.reconciler.EventSourceInitializer;
+import io.javaoperatorsdk.operator.api.reconciler.Reconciler;
+import io.javaoperatorsdk.operator.api.reconciler.UpdateControl;
+import io.javaoperatorsdk.operator.junit.KubernetesClientAware;
+import io.javaoperatorsdk.operator.processing.dependent.kubernetes.KubernetesDependentResourceConfig;
+import io.javaoperatorsdk.operator.processing.event.source.EventSource;
+import io.javaoperatorsdk.operator.support.TestExecutionInfoProvider;
+
+@ControllerConfiguration
+public class MultipleDependentResourceReconciler
+    implements Reconciler<MultipleDependentResourceCustomResource>,
+    TestExecutionInfoProvider, EventSourceInitializer<MultipleDependentResourceCustomResource>,
+    KubernetesClientAware {
+
+  public static final int FIRST_CONFIG_MAP_ID = 1;
+  public static final int SECOND_CONFIG_MAP_ID = 2;
+  public static final String LABEL = "multipledependentresource";
+  private final AtomicInteger numberOfExecutions = new AtomicInteger(0);
+
+  private final MultipleDependentResourceConfigMap firstDependentResourceConfigMap;
+  private final MultipleDependentResourceConfigMap secondDependentResourceConfigMap;
+  private KubernetesClient client;
+
+  public MultipleDependentResourceReconciler() {
+    firstDependentResourceConfigMap = new MultipleDependentResourceConfigMap(FIRST_CONFIG_MAP_ID);
+    secondDependentResourceConfigMap = new MultipleDependentResourceConfigMap(SECOND_CONFIG_MAP_ID);
+
+    firstDependentResourceConfigMap.configureWith(
+        new KubernetesDependentResourceConfig()
+            .setLabelSelector(getLabelSelector(FIRST_CONFIG_MAP_ID)));
+    secondDependentResourceConfigMap.configureWith(
+        new KubernetesDependentResourceConfig()
+            .setLabelSelector(getLabelSelector(SECOND_CONFIG_MAP_ID)));
+  }
+
+  private String getLabelSelector(int resourceId) {
+    return LABEL + "=" + resourceId;
+  }
+
+  @Override
+  public UpdateControl<MultipleDependentResourceCustomResource> reconcile(
+      MultipleDependentResourceCustomResource resource,
+      Context<MultipleDependentResourceCustomResource> context) {
+    numberOfExecutions.getAndIncrement();
+    firstDependentResourceConfigMap.reconcile(resource, context);
+    secondDependentResourceConfigMap.reconcile(resource, context);
+    return UpdateControl.noUpdate();
+  }
+
+
+  public int getNumberOfExecutions() {
+    return numberOfExecutions.get();
+  }
+
+  @Override
+  public Map<String, EventSource> prepareEventSources(
+      EventSourceContext<MultipleDependentResourceCustomResource> context) {
+    return EventSourceInitializer.nameEventSources(
+        firstDependentResourceConfigMap.initEventSource(context),
+        secondDependentResourceConfigMap.initEventSource(context));
+  }
+
+  @Override
+  public KubernetesClient getKubernetesClient() {
+    return client;
+  }
+
+  @Override
+  public void setKubernetesClient(KubernetesClient kubernetesClient) {
+    this.client = kubernetesClient;
+    firstDependentResourceConfigMap.setKubernetesClient(kubernetesClient);
+    secondDependentResourceConfigMap.setKubernetesClient(kubernetesClient);
+  }
+}

operator-framework/src/test/java/io/javaoperatorsdk/operator/sample/multipledependentresource/MultipleDependentResourceStatus.java

@@ -0,0 +1,5 @@
+package io.javaoperatorsdk.operator.sample.multipledependentresource;
+
+public class MultipleDependentResourceStatus {
+
+}

operator-framework/src/test/java/io/javaoperatorsdk/operator/sample/multiplesecondaryeventsource/MultipleSecondaryEventSourceCustomResource.java

@@ -9,8 +9,8 @@
 
 @Group("sample.javaoperatorsdk")
 @Version("v1")
-@Kind("MaxIntervalTestCustomResource")
-@ShortNames("mit")
+@Kind("MultipleSecondaryEventSourceCustomResource")
+@ShortNames("mses")
 public class MultipleSecondaryEventSourceCustomResource
     extends CustomResource<Void, MultipleSecondaryEventSourceStatus>
     implements Namespaced {