fix: replace label selector mock server test with IT

Author: csviri

operator-framework-core/src/test/java/io/javaoperatorsdk/operator/processing/event/source/CustomResourceSelectorTest.java

@@ -0,0 +1,50 @@
+package io.javaoperatorsdk.operator;
+
+import java.time.Duration;
+import java.util.Collections;
+import java.util.Map;
+
+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.labelselector.LabelSelectorTestCustomResource;
+import io.javaoperatorsdk.operator.sample.labelselector.LabelSelectorTestReconciler;
+
+import static io.javaoperatorsdk.operator.sample.labelselector.LabelSelectorTestReconciler.LABEL_KEY;
+import static io.javaoperatorsdk.operator.sample.labelselector.LabelSelectorTestReconciler.LABEL_VALUE;
+import static org.assertj.core.api.Assertions.assertThat;
+import static org.awaitility.Awaitility.await;
+
+class LabelSelectorIT {
+
+  @RegisterExtension
+  LocallyRunOperatorExtension operator =
+      LocallyRunOperatorExtension.builder().withReconciler(new LabelSelectorTestReconciler())
+          .build();
+
+
+  @Test
+  void filtersCustomResourceByLabel() {
+    operator.create(resource("r1", true));
+    operator.create(resource("r2", false));
+
+    await().pollDelay(Duration.ofMillis(150)).untilAsserted(() -> {
+      assertThat(
+          operator.getReconcilerOfType(LabelSelectorTestReconciler.class).getNumberOfExecutions())
+          .isEqualTo(1);
+    });
+  }
+
+  LabelSelectorTestCustomResource resource(String name, boolean addLabel) {
+    var res = new LabelSelectorTestCustomResource();
+    res.setMetadata(new ObjectMetaBuilder()
+        .withName(name)
+        .withLabels(addLabel ? Map.of(LABEL_KEY, LABEL_VALUE)
+            : Collections.emptyMap())
+        .build());
+    return res;
+  }
+
+}

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

@@ -0,0 +1,15 @@
+package io.javaoperatorsdk.operator.sample.labelselector;
+
+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("lst")
+public class LabelSelectorTestCustomResource
+    extends CustomResource<Void, LabelSelectorTestCustomResourceStatus>
+    implements Namespaced {
+}

operator-framework/src/test/java/io/javaoperatorsdk/operator/sample/labelselector/LabelSelectorTestCustomResource.java

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

operator-framework/src/test/java/io/javaoperatorsdk/operator/sample/labelselector/LabelSelectorTestCustomResourceStatus.java

@@ -0,0 +1,31 @@
+package io.javaoperatorsdk.operator.sample.labelselector;
+
+import java.util.concurrent.atomic.AtomicInteger;
+
+import io.javaoperatorsdk.operator.api.reconciler.*;
+import io.javaoperatorsdk.operator.support.TestExecutionInfoProvider;
+
+import static io.javaoperatorsdk.operator.sample.labelselector.LabelSelectorTestReconciler.LABEL_KEY;
+import static io.javaoperatorsdk.operator.sample.labelselector.LabelSelectorTestReconciler.LABEL_VALUE;
+
+@ControllerConfiguration(labelSelector = LABEL_KEY + "=" + LABEL_VALUE)
+public class LabelSelectorTestReconciler
+    implements Reconciler<LabelSelectorTestCustomResource>, TestExecutionInfoProvider {
+
+  public static final String LABEL_KEY = "app";
+  public static final String LABEL_VALUE = "myapp";
+
+  private final AtomicInteger numberOfExecutions = new AtomicInteger(0);
+
+  @Override
+  public UpdateControl<LabelSelectorTestCustomResource> reconcile(
+      LabelSelectorTestCustomResource resource, Context<LabelSelectorTestCustomResource> context) {
+    numberOfExecutions.addAndGet(1);
+    return UpdateControl.noUpdate();
+  }
+
+  public int getNumberOfExecutions() {
+    return numberOfExecutions.get();
+  }
+
+}