add sanity test

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

Author: csviri

gradle/libs.versions.toml

@@ -42,6 +42,7 @@ shadow-jar-plugin = "8.3.6"
 kubernetes-client = { group = "io.fabric8", name = "kubernetes-client", version.ref = "fabric8" }
 kubernetes-httpclient-okhttp = { group = "io.fabric8", name = "kubernetes-httpclient-okhttp", version.ref = "fabric8" }
 kubernetes-server-mock = { group = "io.fabric8", name = "kubernetes-server-mock", version.ref = "fabric8" }
+kube-api-test = {group = "io.fabric8", name = "kube-api-test-client-inject", version.ref = "fabric8"}
 crd-generator-apt = { group = "io.fabric8", name = "crd-generator-apt", version.ref = "fabric8" }
 okhttp = { group = "com.squareup.okhttp3", name = "okhttp", version.ref = "okhttp" }
 mockwebserver = { group = "com.squareup.okhttp3", name = "mockwebserver", version.ref = "okhttp" }

spark-operator/build.gradle

@@ -80,6 +80,7 @@ dependencies {
   testRuntimeOnly(libs.junit.platform.launcher)
 
   testImplementation(libs.mockito.core)
+  testImplementation(libs.kube.api.test)
 }
 
 test {

spark-operator/src/test/java/org/apache/spark/k8s/operator/config/SparkOperatorConfigMapReconcilerTest.java

@@ -0,0 +1,63 @@
+package org.apache.spark.k8s.operator.config;
+
+import static org.apache.spark.k8s.operator.config.SparkOperatorConf.RECONCILER_INTERVAL_SECONDS;
+import static org.assertj.core.api.Assertions.assertThat;
+import static org.awaitility.Awaitility.await;
+import static org.mockito.Mockito.mock;
+
+import java.util.Map;
+import java.util.function.Function;
+
+import io.fabric8.kubeapitest.junit.EnableKubeAPIServer;
+import io.fabric8.kubernetes.api.model.ConfigMap;
+import io.fabric8.kubernetes.api.model.ObjectMetaBuilder;
+import io.fabric8.kubernetes.client.KubernetesClient;
+import io.javaoperatorsdk.operator.Operator;
+import org.junit.jupiter.api.AfterEach;
+import org.junit.jupiter.api.BeforeEach;
+import org.junit.jupiter.api.Test;
+
+@EnableKubeAPIServer
+class SparkOperatorConfigMapReconcilerTest {
+
+  public static final Long TARGET_RECONCILER_INTERVAL = 60L;
+  static KubernetesClient client;
+
+  Operator operator;
+
+  @BeforeEach
+  void startController() {
+    var namespaceUpdater = mock(Function.class);
+    var watchedNamespaceGetter = mock(Function.class);
+
+    var reconciler = new SparkOperatorConfigMapReconciler(namespaceUpdater, watchedNamespaceGetter);
+    operator = new Operator(o -> o.withKubernetesClient(client));
+    operator.register(reconciler);
+    operator.start();
+  }
+
+  @AfterEach
+  void stopController() {
+    operator.stop();
+  }
+
+  @Test
+  void sanityTest() {
+    client.resource(testConfigMap()).create();
+
+    await()
+        .untilAsserted(
+            () -> {
+              assertThat(RECONCILER_INTERVAL_SECONDS.getValue()).isEqualTo(60L);
+            });
+  }
+
+  ConfigMap testConfigMap() {
+    ConfigMap configMap = new ConfigMap();
+    configMap.setMetadata(
+        new ObjectMetaBuilder().withName("spark-conf").withNamespace("default").build());
+    configMap.setData(
+        Map.of(RECONCILER_INTERVAL_SECONDS.getKey(), TARGET_RECONCILER_INTERVAL.toString()));
+    return configMap;
+  }
+}