Integration test

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

Author: csviri

operator-framework/src/test/java/io/javaoperatorsdk/operator/baseapi/statuscache/updatecontrol/UpdateControlPrimaryCacheCustomResource.java

@@ -0,0 +1,14 @@
+package io.javaoperatorsdk.operator.baseapi.statuscache.updatecontrol;
+
+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.ShortNames;
+import io.fabric8.kubernetes.model.annotation.Version;
+
+@Group("sample.javaoperatorsdk")
+@Version("v1")
+@ShortNames("ucpc")
+public class UpdateControlPrimaryCacheCustomResource
+    extends CustomResource<UpdateControlPrimaryCacheSpec, UpdateControlPrimaryCacheStatus>
+    implements Namespaced {}

operator-framework/src/test/java/io/javaoperatorsdk/operator/baseapi/statuscache/updatecontrol/UpdateControlPrimaryCacheIT.java

@@ -0,0 +1,52 @@
+package io.javaoperatorsdk.operator.baseapi.statuscache.updatecontrol;
+
+import java.time.Duration;
+
+import org.junit.jupiter.api.Test;
+import org.junit.jupiter.api.extension.RegisterExtension;
+
+import io.fabric8.kubernetes.api.model.ObjectMetaBuilder;
+import io.javaoperatorsdk.operator.junit.LocallyRunOperatorExtension;
+
+import static org.assertj.core.api.Assertions.assertThat;
+import static org.awaitility.Awaitility.await;
+
+public class UpdateControlPrimaryCacheIT {
+
+  public static final String TEST_1 = "test1";
+
+  @RegisterExtension
+  LocallyRunOperatorExtension extension =
+      LocallyRunOperatorExtension.builder()
+          .withReconciler(UpdateControlPrimaryReconciler.class)
+          .withConfigurationService(
+              o ->
+                  o.withParseResourceVersions(true)
+                      .withGuaranteeUpdatedPrimaryIsAvailableForNextReconciliation(true))
+          .build();
+
+  @Test
+  void testStatusAlwaysUpToDate() {
+    var reconciler = extension.getReconcilerOfType(UpdateControlPrimaryReconciler.class);
+
+    extension.create(testResource());
+
+    // the reconciliation is periodically triggered, the status values should be increasing
+    // monotonically
+    await()
+        .pollDelay(Duration.ofSeconds(1))
+        .pollInterval(Duration.ofMillis(30))
+        .untilAsserted(
+            () -> {
+              assertThat(reconciler.errorPresent).isFalse();
+              assertThat(reconciler.latestValue).isGreaterThan(10);
+            });
+  }
+
+  UpdateControlPrimaryCacheCustomResource testResource() {
+    var res = new UpdateControlPrimaryCacheCustomResource();
+    res.setMetadata(new ObjectMetaBuilder().withName(TEST_1).build());
+    res.setSpec(new UpdateControlPrimaryCacheSpec());
+    return res;
+  }
+}

operator-framework/src/test/java/io/javaoperatorsdk/operator/baseapi/statuscache/updatecontrol/UpdateControlPrimaryCacheSpec.java

@@ -0,0 +1,14 @@
+package io.javaoperatorsdk.operator.baseapi.statuscache.updatecontrol;
+
+public class UpdateControlPrimaryCacheSpec {
+
+  private int counter = 0;
+
+  public int getCounter() {
+    return counter;
+  }
+
+  public void setCounter(int counter) {
+    this.counter = counter;
+  }
+}

operator-framework/src/test/java/io/javaoperatorsdk/operator/baseapi/statuscache/updatecontrol/UpdateControlPrimaryCacheStatus.java

@@ -0,0 +1,15 @@
+package io.javaoperatorsdk.operator.baseapi.statuscache.updatecontrol;
+
+public class UpdateControlPrimaryCacheStatus {
+
+  private Integer value = 0;
+
+  public Integer getValue() {
+    return value;
+  }
+
+  public UpdateControlPrimaryCacheStatus setValue(Integer value) {
+    this.value = value;
+    return this;
+  }
+}

operator-framework/src/test/java/io/javaoperatorsdk/operator/baseapi/statuscache/updatecontrol/UpdateControlPrimaryReconciler.java

@@ -0,0 +1,62 @@
+package io.javaoperatorsdk.operator.baseapi.statuscache.updatecontrol;
+
+import java.util.List;
+
+import io.fabric8.kubernetes.api.model.ObjectMetaBuilder;
+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.Reconciler;
+import io.javaoperatorsdk.operator.api.reconciler.UpdateControl;
+import io.javaoperatorsdk.operator.baseapi.statuscache.PeriodicTriggerEventSource;
+import io.javaoperatorsdk.operator.processing.event.source.EventSource;
+
+@ControllerConfiguration
+public class UpdateControlPrimaryReconciler
+    implements Reconciler<UpdateControlPrimaryCacheCustomResource> {
+
+  public volatile int latestValue = 0;
+  public volatile boolean errorPresent = false;
+
+  @Override
+  public UpdateControl<UpdateControlPrimaryCacheCustomResource> reconcile(
+      UpdateControlPrimaryCacheCustomResource resource,
+      Context<UpdateControlPrimaryCacheCustomResource> context) {
+
+    if (resource.getStatus() != null && resource.getStatus().getValue() != latestValue) {
+      errorPresent = true;
+      throw new IllegalStateException(
+          "status is not up to date. Latest value: "
+              + latestValue
+              + " status values: "
+              + resource.getStatus().getValue());
+    }
+
+    var freshCopy = createFreshCopy(resource);
+
+    latestValue = resource.getStatus() == null ? 1 : resource.getStatus().getValue() + 1;
+    freshCopy.getStatus().setValue(latestValue);
+
+    return UpdateControl.patchStatus(freshCopy);
+  }
+
+  @Override
+  public List<EventSource<?, UpdateControlPrimaryCacheCustomResource>> prepareEventSources(
+      EventSourceContext<UpdateControlPrimaryCacheCustomResource> context) {
+    // periodic event triggering for testing purposes
+    return List.of(new PeriodicTriggerEventSource<>(context.getPrimaryCache()));
+  }
+
+  private UpdateControlPrimaryCacheCustomResource createFreshCopy(
+      UpdateControlPrimaryCacheCustomResource resource) {
+    var res = new UpdateControlPrimaryCacheCustomResource();
+    res.setMetadata(
+        new ObjectMetaBuilder()
+            .withName(resource.getMetadata().getName())
+            .withNamespace(resource.getMetadata().getNamespace())
+            .build());
+    res.setStatus(new UpdateControlPrimaryCacheStatus());
+
+    return res;
+  }
+}