Integration test

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

Author: csviri

operator-framework/src/test/java/io/javaoperatorsdk/operator/baseapi/statuscache/internal/StatusPatchCacheIT.java

@@ -18,6 +18,7 @@ public class StatusPatchCacheIT {
   @RegisterExtension
   LocallyRunOperatorExtension extension =
       LocallyRunOperatorExtension.builder()
+          .withConfigurationService(o -> o.withParseResourceVersions(true))
           .withReconciler(StatusPatchCacheReconciler.class)
           .build();
 

operator-framework/src/test/java/io/javaoperatorsdk/operator/baseapi/statuscache/internalwithlock/StatusPatchCacheWithLockCustomResource.java

@@ -0,0 +1,14 @@
+package io.javaoperatorsdk.operator.baseapi.statuscache.internalwithlock;
+
+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("spwl")
+public class StatusPatchCacheWithLockCustomResource
+    extends CustomResource<StatusPatchCacheWithLockSpec, StatusPatchCacheWithLockStatus>
+    implements Namespaced {}

operator-framework/src/test/java/io/javaoperatorsdk/operator/baseapi/statuscache/internalwithlock/StatusPatchCacheWithLockIT.java

@@ -0,0 +1,48 @@
+package io.javaoperatorsdk.operator.baseapi.statuscache.internalwithlock;
+
+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 StatusPatchCacheWithLockIT {
+
+  public static final String TEST_1 = "test1";
+
+  @RegisterExtension
+  LocallyRunOperatorExtension extension =
+      LocallyRunOperatorExtension.builder()
+          .withReconciler(StatusPatchCacheWithLockReconciler.class)
+          .build();
+
+  @Test
+  void testStatusAlwaysUpToDate() {
+    var reconciler = extension.getReconcilerOfType(StatusPatchCacheWithLockReconciler.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);
+            });
+  }
+
+  StatusPatchCacheWithLockCustomResource testResource() {
+    var res = new StatusPatchCacheWithLockCustomResource();
+    res.setMetadata(new ObjectMetaBuilder().withName(TEST_1).build());
+    res.setSpec(new StatusPatchCacheWithLockSpec());
+    return res;
+  }
+}

operator-framework/src/test/java/io/javaoperatorsdk/operator/baseapi/statuscache/internalwithlock/StatusPatchCacheWithLockReconciler.java

@@ -0,0 +1,69 @@
+package io.javaoperatorsdk.operator.baseapi.statuscache.internalwithlock;
+
+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.PrimaryUpdateAndCacheUtils;
+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 StatusPatchCacheWithLockReconciler
+    implements Reconciler<StatusPatchCacheWithLockCustomResource> {
+
+  public volatile int latestValue = 0;
+  public volatile boolean errorPresent = false;
+
+  @Override
+  public UpdateControl<StatusPatchCacheWithLockCustomResource> reconcile(
+      StatusPatchCacheWithLockCustomResource resource,
+      Context<StatusPatchCacheWithLockCustomResource> 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);
+
+    freshCopy
+        .getStatus()
+        .setValue(resource.getStatus() == null ? 1 : resource.getStatus().getValue() + 1);
+
+    var updated =
+        PrimaryUpdateAndCacheUtils.ssaPatchStatusAndCacheResourceWithLock(
+            resource, freshCopy, context);
+    latestValue = updated.getStatus().getValue();
+
+    return UpdateControl.noUpdate();
+  }
+
+  @Override
+  public List<EventSource<?, StatusPatchCacheWithLockCustomResource>> prepareEventSources(
+      EventSourceContext<StatusPatchCacheWithLockCustomResource> context) {
+    // periodic event triggering for testing purposes
+    return List.of(new PeriodicTriggerEventSource<>(context.getPrimaryCache()));
+  }
+
+  private StatusPatchCacheWithLockCustomResource createFreshCopy(
+      StatusPatchCacheWithLockCustomResource resource) {
+    var res = new StatusPatchCacheWithLockCustomResource();
+    res.setMetadata(
+        new ObjectMetaBuilder()
+            .withName(resource.getMetadata().getName())
+            .withNamespace(resource.getMetadata().getNamespace())
+            .build());
+    res.setStatus(new StatusPatchCacheWithLockStatus());
+
+    return res;
+  }
+}

operator-framework/src/test/java/io/javaoperatorsdk/operator/baseapi/statuscache/internalwithlock/StatusPatchCacheWithLockSpec.java

@@ -0,0 +1,14 @@
+package io.javaoperatorsdk.operator.baseapi.statuscache.internalwithlock;
+
+public class StatusPatchCacheWithLockSpec {
+
+  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/internalwithlock/StatusPatchCacheWithLockStatus.java

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