wip

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

Author: csviri

operator-framework/src/test/java/io/javaoperatorsdk/operator/baseapi/changenamespace/ChangeNamespaceTestReconciler.java

@@ -53,15 +53,7 @@ public UpdateControl<ChangeNamespaceTestCustomResource> reconcile(
       ChangeNamespaceTestCustomResource primary,
       Context<ChangeNamespaceTestCustomResource> context) {
 
-    var actualConfigMap = context.getSecondaryResource(ConfigMap.class);
-    if (actualConfigMap.isEmpty()) {
-      context
-          .getClient()
-          .configMaps()
-          .inNamespace(primary.getMetadata().getNamespace())
-          .resource(configMap(primary))
-          .create();
-    }
+    ReconcileUtils.serverSideApply(context, configMap(primary));
 
     if (primary.getStatus() == null) {
       primary.setStatus(new ChangeNamespaceTestCustomResourceStatus());

operator-framework/src/test/java/io/javaoperatorsdk/operator/baseapi/generickubernetesresourcehandling/GenericKubernetesResourceHandlingReconciler.java

@@ -17,7 +17,6 @@
 
 import java.io.IOException;
 import java.io.InputStream;
-import java.util.HashMap;
 import java.util.List;
 import java.util.Map;
 
@@ -41,36 +40,11 @@ public UpdateControl<GenericKubernetesResourceHandlingCustomResource> reconcile(
       GenericKubernetesResourceHandlingCustomResource primary,
       Context<GenericKubernetesResourceHandlingCustomResource> context) {
 
-    var secondary = context.getSecondaryResource(GenericKubernetesResource.class);
-
-    secondary.ifPresentOrElse(
-        r -> {
-          var desired = desiredConfigMap(primary, context);
-          if (!matches(r, desired)) {
-            context
-                .getClient()
-                .genericKubernetesResources(VERSION, KIND)
-                .resource(desired)
-                .update();
-          }
-        },
-        () ->
-            context
-                .getClient()
-                .genericKubernetesResources(VERSION, KIND)
-                .resource(desiredConfigMap(primary, context))
-                .create());
+    ReconcileUtils.serverSideApply(context, desiredConfigMap(primary, context));
 
     return UpdateControl.noUpdate();
   }
 
-  @SuppressWarnings("unchecked")
-  private boolean matches(GenericKubernetesResource actual, GenericKubernetesResource desired) {
-    var actualData = (HashMap<String, String>) actual.getAdditionalProperties().get("data");
-    var desiredData = (HashMap<String, String>) desired.getAdditionalProperties().get("data");
-    return actualData.equals(desiredData);
-  }
-
   GenericKubernetesResource desiredConfigMap(
       GenericKubernetesResourceHandlingCustomResource primary,
       Context<GenericKubernetesResourceHandlingCustomResource> context) {

operator-framework/src/test/java/io/javaoperatorsdk/operator/baseapi/multiplesecondaryeventsource/MultipleSecondaryEventSourceReconciler.java

@@ -26,6 +26,7 @@
 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.ReconcileUtils;
 import io.javaoperatorsdk.operator.api.reconciler.Reconciler;
 import io.javaoperatorsdk.operator.api.reconciler.UpdateControl;
 import io.javaoperatorsdk.operator.processing.event.ResourceID;
@@ -53,31 +54,8 @@ public UpdateControl<MultipleSecondaryEventSourceCustomResource> reconcile(
       Context<MultipleSecondaryEventSourceCustomResource> context) {
     numberOfExecutions.addAndGet(1);
 
-    final var client = context.getClient();
-    if (client
-            .configMaps()
-            .inNamespace(resource.getMetadata().getNamespace())
-            .withName(getName1(resource))
-            .get()
-        == null) {
-      client
-          .configMaps()
-          .inNamespace(resource.getMetadata().getNamespace())
-          .resource(configMap(getName1(resource), resource))
-          .createOrReplace();
-    }
-    if (client
-            .configMaps()
-            .inNamespace(resource.getMetadata().getNamespace())
-            .withName(getName2(resource))
-            .get()
-        == null) {
-      client
-          .configMaps()
-          .inNamespace(resource.getMetadata().getNamespace())
-          .resource(configMap(getName2(resource), resource))
-          .createOrReplace();
-    }
+    ReconcileUtils.serverSideApply(context, configMap(getName1(resource), resource));
+    ReconcileUtils.serverSideApply(context, configMap(getName2(resource), resource));
 
     if (numberOfExecutions.get() >= 3) {
       if (context.getSecondaryResources(ConfigMap.class).size() != 2) {

operator-framework/src/test/java/io/javaoperatorsdk/operator/dependent/externalstate/ExternalStateReconciler.java

@@ -32,6 +32,7 @@
 import io.javaoperatorsdk.operator.api.reconciler.ControllerConfiguration;
 import io.javaoperatorsdk.operator.api.reconciler.DeleteControl;
 import io.javaoperatorsdk.operator.api.reconciler.EventSourceContext;
+import io.javaoperatorsdk.operator.api.reconciler.ReconcileUtils;
 import io.javaoperatorsdk.operator.api.reconciler.Reconciler;
 import io.javaoperatorsdk.operator.api.reconciler.UpdateControl;
 import io.javaoperatorsdk.operator.processing.event.ResourceID;
@@ -110,7 +111,7 @@ private void createExternalResource(
     // This is critical in this case, since on next reconciliation if it would not be in the cache
     // it would be created again.
     configMapEventSource.eventFilteringUpdateAndCacheResource(
-        configMap, toCreate -> context.getClient().configMaps().resource(toCreate).create());
+        configMap, toCreate -> ReconcileUtils.serverSideApply(context, toCreate));
     externalResourceEventSource.handleRecentResourceCreate(primaryID, createdResource);
   }