integration test for ignore list

Author: csviri

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

@@ -0,0 +1,52 @@
+package io.javaoperatorsdk.operator;
+
+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 io.javaoperatorsdk.operator.sample.servicestrictmatcher.ServiceDependentResource;
+import io.javaoperatorsdk.operator.sample.servicestrictmatcher.ServiceStrictMatcherSpec;
+import io.javaoperatorsdk.operator.sample.servicestrictmatcher.ServiceStrictMatcherTestCustomResource;
+import io.javaoperatorsdk.operator.sample.servicestrictmatcher.ServiceStrictMatcherTestReconciler;
+
+import static org.assertj.core.api.Assertions.assertThat;
+import static org.awaitility.Awaitility.await;
+
+public class ServiceStrictMatcherIT {
+
+  @RegisterExtension
+  LocallyRunOperatorExtension operator =
+      LocallyRunOperatorExtension.builder().withReconciler(new ServiceStrictMatcherTestReconciler())
+          .build();
+
+
+  @Test
+  void testTheMatchingDoesNoTTriggersFurtherUpdates() {
+    var resource = operator.create(testResource());
+
+    // make an update to spec to reconcile again
+    resource.getSpec().setValue(2);
+    operator.replace(resource);
+
+    await().pollDelay(Duration.ofMillis(300)).untilAsserted(() -> {
+      assertThat(operator.getReconcilerOfType(ServiceStrictMatcherTestReconciler.class)
+          .getNumberOfExecutions()).isEqualTo(2);
+      assertThat(ServiceDependentResource.updated.get()).isEqualTo(0);
+    });
+  }
+
+
+  ServiceStrictMatcherTestCustomResource testResource() {
+    var res = new ServiceStrictMatcherTestCustomResource();
+    res.setSpec(new ServiceStrictMatcherSpec());
+    res.getSpec().setValue(1);
+    res.setMetadata(new ObjectMetaBuilder()
+        .withName("test1")
+        .build());
+    return res;
+  }
+
+}

operator-framework/src/test/java/io/javaoperatorsdk/operator/sample/servicestrictmatcher/ServiceDependentResource.java

@@ -0,0 +1,62 @@
+package io.javaoperatorsdk.operator.sample.servicestrictmatcher;
+
+import java.util.HashMap;
+import java.util.Map;
+import java.util.concurrent.atomic.AtomicInteger;
+
+import io.fabric8.kubernetes.api.model.Service;
+import io.javaoperatorsdk.operator.ServiceStrictMatcherIT;
+import io.javaoperatorsdk.operator.api.reconciler.Context;
+import io.javaoperatorsdk.operator.processing.dependent.Matcher;
+import io.javaoperatorsdk.operator.processing.dependent.kubernetes.CRUDKubernetesDependentResource;
+import io.javaoperatorsdk.operator.processing.dependent.kubernetes.GenericKubernetesResourceMatcher;
+import io.javaoperatorsdk.operator.processing.dependent.kubernetes.KubernetesDependent;
+
+import static io.javaoperatorsdk.operator.ReconcilerUtils.loadYaml;
+
+@KubernetesDependent
+public class ServiceDependentResource
+    extends CRUDKubernetesDependentResource<Service, ServiceStrictMatcherTestCustomResource> {
+
+  public static AtomicInteger updated = new AtomicInteger(0);
+
+  public ServiceDependentResource() {
+    super(Service.class);
+  }
+
+  @Override
+  protected Service desired(ServiceStrictMatcherTestCustomResource primary,
+      Context<ServiceStrictMatcherTestCustomResource> context) {
+    Service service = loadYaml(Service.class, ServiceStrictMatcherIT.class, "service.yaml");
+    service.getMetadata().setName(primary.getMetadata().getName());
+    service.getMetadata().setNamespace(primary.getMetadata().getNamespace());
+    Map<String, String> labels = new HashMap<>();
+    labels.put("app", "deployment-name");
+    service.getSpec().setSelector(labels);
+    return service;
+  }
+
+  @Override
+  public Matcher.Result<Service> match(Service actualResource,
+      ServiceStrictMatcherTestCustomResource primary,
+      Context<ServiceStrictMatcherTestCustomResource> context) {
+    return GenericKubernetesResourceMatcher.match(this, actualResource, primary, context, false,
+        false,
+        "/spec/ports",
+        "/spec/clusterIP",
+        "/spec/clusterIPs",
+        "/spec/externalTrafficPolicy",
+        "/spec/internalTrafficPolicy",
+        "/spec/ipFamilies",
+        "/spec/ipFamilyPolicy",
+        "/spec/sessionAffinity");
+  }
+
+  @Override
+  public Service update(Service actual, Service target,
+      ServiceStrictMatcherTestCustomResource primary,
+      Context<ServiceStrictMatcherTestCustomResource> context) {
+    updated.addAndGet(1);
+    return super.update(actual, target, primary, context);
+  }
+}

operator-framework/src/test/java/io/javaoperatorsdk/operator/sample/servicestrictmatcher/ServiceStrictMatcherSpec.java

@@ -0,0 +1,15 @@
+package io.javaoperatorsdk.operator.sample.servicestrictmatcher;
+
+public class ServiceStrictMatcherSpec {
+
+  private int value;
+
+  public int getValue() {
+    return value;
+  }
+
+  public ServiceStrictMatcherSpec setValue(int value) {
+    this.value = value;
+    return this;
+  }
+}

operator-framework/src/test/java/io/javaoperatorsdk/operator/sample/servicestrictmatcher/ServiceStrictMatcherTestCustomResource.java

@@ -0,0 +1,16 @@
+package io.javaoperatorsdk.operator.sample.servicestrictmatcher;
+
+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("ssm")
+public class ServiceStrictMatcherTestCustomResource
+    extends CustomResource<ServiceStrictMatcherSpec, Void>
+    implements Namespaced {
+
+}

operator-framework/src/test/java/io/javaoperatorsdk/operator/sample/servicestrictmatcher/ServiceStrictMatcherTestReconciler.java

@@ -0,0 +1,29 @@
+package io.javaoperatorsdk.operator.sample.servicestrictmatcher;
+
+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(type = ServiceDependentResource.class)})
+public class ServiceStrictMatcherTestReconciler
+    implements Reconciler<ServiceStrictMatcherTestCustomResource> {
+
+
+  private final AtomicInteger numberOfExecutions = new AtomicInteger(0);
+
+  @Override
+  public UpdateControl<ServiceStrictMatcherTestCustomResource> reconcile(
+      ServiceStrictMatcherTestCustomResource resource,
+      Context<ServiceStrictMatcherTestCustomResource> context) {
+    numberOfExecutions.addAndGet(1);
+    return UpdateControl.noUpdate();
+  }
+
+  public int getNumberOfExecutions() {
+    return numberOfExecutions.get();
+  }
+}

operator-framework/src/test/resources/io/javaoperatorsdk/operator/service.yaml

@@ -0,0 +1,12 @@
+apiVersion: v1
+kind: Service
+metadata:
+  name: ""
+spec:
+  selector:
+    app: ""
+  ports:
+    - protocol: TCP
+      port: 80
+      targetPort: 80
+  type: NodePort