operator test

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

Author: csviri

src/test/java/io/javaoperatorsdk/operator/glue/GlueOperatorTest.java

@@ -4,6 +4,7 @@
 import java.util.ArrayList;
 import java.util.stream.IntStream;
 
+import io.javaoperatorsdk.operator.glue.reconciler.operator.GlueOperatorReconciler;
 import org.junit.jupiter.api.BeforeEach;
 import org.junit.jupiter.api.Test;
 
@@ -229,6 +230,40 @@ void secretCopySample() {
     });
   }
 
+  @Test
+  void operatorWithBulkResource() {
+    var go = create(TestUtils
+        .loadGlueOperator("/glueoperator/BulkOperator.yaml"));
+
+    var cr = testCustomResource();
+    cr.getSpec().setReplicas(2);
+    var createdCR = create(cr);
+    assertConfigMapsCreated(cr, 2);
+
+    createdCR.getSpec().setReplicas(3);
+    createdCR = update(createdCR);
+    assertConfigMapsCreated(cr, 3);
+
+    createdCR.getSpec().setReplicas(1);
+    createdCR = update(createdCR);
+    assertConfigMapsCreated(cr, 1);
+
+    delete(createdCR);
+    assertConfigMapsCreated(cr, 0);
+    await().untilAsserted(()->{
+      var actualCR = get(TestCustomResource.class,cr.getMetadata().getName());
+      assertThat(actualCR).isNull();
+    });
+
+    delete(go);
+  }
+
+  private void assertConfigMapsCreated(TestCustomResource cr, int expected) {
+    await().untilAsserted(() -> {
+      var configMaps = getRelatedList(ConfigMap.class, GlueOperatorReconciler.glueName(cr.getMetadata().getName(),cr.getKind()));
+      assertThat(configMaps).hasSize(expected);
+    });
+  }
 
   GlueOperator testWorkflowOperator() {
     var wo = new GlueOperator();

src/test/java/io/javaoperatorsdk/operator/glue/GlueTest.java

@@ -373,7 +373,7 @@ void simpleBulk() {
     var glue = createGlue("/glue/" + "SimpleBulk.yaml");
 
     await().untilAsserted(() -> {
-      var configMaps = getRelatedConfigMaps(glue.getMetadata().getName());
+      var configMaps = getRelatedList(ConfigMap.class, glue.getMetadata().getName());
       assertThat(configMaps).hasSize(3);
       assertThat(configMaps)
           .allMatch(cm -> cm.getMetadata().getName().startsWith("simple-glue-configmap-"));
@@ -382,16 +382,10 @@ void simpleBulk() {
     delete(glue);
 
     await().untilAsserted(
-        () -> assertThat(getRelatedConfigMaps(glue.getMetadata().getName())).isEmpty());
+        () -> assertThat(getRelatedList(ConfigMap.class, glue.getMetadata().getName()).isEmpty()));
   }
 
-  List<ConfigMap> getRelatedConfigMaps(String ownerName) {
-    return list(ConfigMap.class).stream()
-        .filter(cm -> !cm.getMetadata().getOwnerReferences().isEmpty()
-            && cm.getMetadata().getOwnerReferences()
-                .get(0).getName().equals(ownerName))
-        .toList();
-  }
+
 
   private List<Glue> testWorkflowList(int num) {
     List<Glue> res = new ArrayList<>();

src/test/java/io/javaoperatorsdk/operator/glue/TestBase.java

@@ -75,6 +75,14 @@ protected <T extends HasMetadata> List<T> list(Class<T> clazz) {
     return client.resources(clazz).inNamespace(testNamespace).list().getItems();
   }
 
+  protected <T extends HasMetadata> List<T> getRelatedList(Class<T> clazz, String ownerName) {
+    return list(clazz).stream()
+        .filter(cm -> !cm.getMetadata().getOwnerReferences().isEmpty()
+            && cm.getMetadata().getOwnerReferences()
+                .get(0).getName().equals(ownerName))
+        .toList();
+  }
+
   protected <T extends HasMetadata> T update(T resource) {
     resource.getMetadata().setResourceVersion(null);
     return client.resource(resource).inNamespace(testNamespace).update();

src/test/java/io/javaoperatorsdk/operator/glue/customresource/TestCustomResourceSpec.java

@@ -6,6 +6,8 @@ public class TestCustomResourceSpec {
 
   private String value;
 
+  private Integer replicas;
+
   private List<String> listValues;
 
   public String getValue() {
@@ -25,4 +27,13 @@ public TestCustomResourceSpec setListValues(List<String> listValues) {
     this.listValues = listValues;
     return this;
   }
+
+
+  public Integer getReplicas() {
+    return replicas;
+  }
+
+  public void setReplicas(Integer replicas) {
+    this.replicas = replicas;
+  }
 }

src/test/resources/glueoperator/BulkOperator.yaml

@@ -0,0 +1,21 @@
+apiVersion: io.javaoperatorsdk.operator.glue/v1beta1
+kind: GlueOperator
+metadata:
+  name: templating-sample
+spec:
+  parent:
+    apiVersion: io.javaoperatorsdk.operator.glue/v1
+    kind: TestCustomResource
+  childResources:
+    - name: configMap1
+      bulk: true
+      resourceTemplate: |
+        items:
+        {#for i in parent.spec.replicas}
+        - apiVersion: v1
+          kind: ConfigMap
+          metadata:
+            name: {parent.metadata.name}-{i}
+          data:
+            key: "value{i}"
+        {/for}