fix: incorrect logic by introducing createOrUpdate method

Signed-off-by: Chris Laprun <metacosm@gmail.com>

Author: metacosm

sample-operators/webpage/src/main/java/io/javaoperatorsdk/operator/sample/WebPageReconciler.java

@@ -19,8 +19,8 @@
 import java.util.List;
 import java.util.Map;
 import java.util.Objects;
+import java.util.function.BiFunction;
 
-import org.apache.commons.lang3.StringUtils;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
@@ -90,55 +90,30 @@ public UpdateControl<WebPage> reconcile(WebPage webPage, Context<WebPage> contex
       return UpdateControl.patchStatus(setInvalidHtmlErrorMessage(webPage));
     }
 
-    String ns = webPage.getMetadata().getNamespace();
-    String configMapName = configMapName(webPage);
-    String deploymentName = deploymentName(webPage);
+    ConfigMap desiredHtmlConfigMap = makeDesiredHtmlConfigMap(webPage);
+    Deployment desiredDeployment = makeDesiredDeployment(webPage);
+    Service desiredService = makeDesiredService(webPage, desiredDeployment);
 
-    ConfigMap desiredHtmlConfigMap = makeDesiredHtmlConfigMap(ns, configMapName, webPage);
-    Deployment desiredDeployment =
-        makeDesiredDeployment(webPage, deploymentName, ns, configMapName);
-    Service desiredService = makeDesiredService(webPage, ns, desiredDeployment);
-
-    var previousConfigMap = context.getSecondaryResource(ConfigMap.class).orElse(null);
-    if (!match(desiredHtmlConfigMap, previousConfigMap)) {
-      log.info(
-          "Creating or updating ConfigMap {} in {}",
-          desiredHtmlConfigMap.getMetadata().getName(),
-          ns);
-      context.resourceOperations().serverSideApply(desiredHtmlConfigMap);
-    }
-
-    var existingDeployment = context.getSecondaryResource(Deployment.class).orElse(null);
-    if (!match(desiredDeployment, existingDeployment)) {
-      log.info(
-          "Creating or updating Deployment {} in {}",
-          desiredDeployment.getMetadata().getName(),
-          ns);
-      context.resourceOperations().serverSideApply(desiredDeployment);
-    }
-
-    var existingService = context.getSecondaryResource(Service.class).orElse(null);
-    if (!match(desiredService, existingService)) {
-      log.info(
-          "Creating or updating Service {} in {}", desiredDeployment.getMetadata().getName(), ns);
-      context.resourceOperations().serverSideApply(desiredService);
-    }
+    final var previousConfigMap = createOrUpdate(context, desiredHtmlConfigMap, this::match);
+    createOrUpdate(context, desiredDeployment, this::match);
+    createOrUpdate(context, desiredService, this::match);
 
     var existingIngress = context.getSecondaryResource(Ingress.class);
     if (Boolean.TRUE.equals(webPage.getSpec().getExposed())) {
       var desiredIngress = makeDesiredIngress(webPage);
       if (existingIngress.isEmpty() || !match(desiredIngress, existingIngress.get())) {
-        context.resourceOperations().serverSideApply(desiredDeployment);
+        context.resourceOperations().serverSideApply(desiredIngress);
       }
     } else existingIngress.ifPresent(ingress -> context.getClient().resource(ingress).delete());
 
     // not that this is not necessary, eventually mounted config map would be updated, just this way
-    // is much faster; what is handy for demo purposes.
+    // is much faster; this is handy for demo purposes.
     // https://kubernetes.io/docs/tasks/configure-pod-container/configure-pod-configmap/#mounted-configmaps-are-updated-automatically
     if (previousConfigMap != null
-        && !StringUtils.equals(
+        && !Objects.equals(
             previousConfigMap.getData().get(INDEX_HTML),
             desiredHtmlConfigMap.getData().get(INDEX_HTML))) {
+      final var ns = webPage.getMetadata().getNamespace();
       log.info("Restarting pods because HTML has changed in {}", ns);
       context.getClient().pods().inNamespace(ns).withLabel("app", deploymentName(webPage)).delete();
     }
@@ -147,6 +122,20 @@ public UpdateControl<WebPage> reconcile(WebPage webPage, Context<WebPage> contex
         createWebPageForStatusUpdate(webPage, desiredHtmlConfigMap.getMetadata().getName()));
   }
 
+
+  private <T extends HasMetadata> T createOrUpdate(Context<WebPage> context, T desired, BiFunction<T, T, Boolean> matcher) {
+    @SuppressWarnings("unchecked") final T previous = (T) context.getSecondaryResource(desired.getClass()).orElse(null);
+    if (!matcher.apply(desired, previous)) {
+      log.info(
+              "Creating or updating {} {} in {}",
+              desired.getKind(),
+              desired.getMetadata().getName(),
+              desired.getMetadata().getNamespace());
+      context.resourceOperations().serverSideApply(desired);
+    }
+    return previous;
+  }
+
   private boolean match(Ingress desiredIngress, Ingress existingIngress) {
     String desiredServiceName =
         desiredIngress
@@ -205,9 +194,10 @@ private boolean match(ConfigMap desiredHtmlConfigMap, ConfigMap existingConfigMa
     }
   }
 
-  private Service makeDesiredService(WebPage webPage, String ns, Deployment desiredDeployment) {
+  private Service makeDesiredService(WebPage webPage, Deployment desiredDeployment) {
     Service desiredService =
         ReconcilerUtilsInternal.loadYaml(Service.class, getClass(), "service.yaml");
+    final var ns = webPage.getMetadata().getNamespace();
     desiredService.getMetadata().setName(serviceName(webPage));
     desiredService.getMetadata().setNamespace(ns);
     desiredService.getMetadata().setLabels(lowLevelLabel());
@@ -218,15 +208,18 @@ private Service makeDesiredService(WebPage webPage, String ns, Deployment desire
     return desiredService;
   }
 
-  private Deployment makeDesiredDeployment(
-      WebPage webPage, String deploymentName, String ns, String configMapName) {
+  private Deployment makeDesiredDeployment(WebPage webPage) {
     Deployment desiredDeployment =
         ReconcilerUtilsInternal.loadYaml(Deployment.class, getClass(), "deployment.yaml");
+    final var ns = webPage.getMetadata().getNamespace();
+    final var deploymentName = deploymentName(webPage);
     desiredDeployment.getMetadata().setName(deploymentName);
     desiredDeployment.getMetadata().setNamespace(ns);
     desiredDeployment.getMetadata().setLabels(lowLevelLabel());
     desiredDeployment.getSpec().getSelector().getMatchLabels().put("app", deploymentName);
     desiredDeployment.getSpec().getTemplate().getMetadata().getLabels().put("app", deploymentName);
+
+    final var configMapName = configMapName(webPage);
     desiredDeployment
         .getSpec()
         .getTemplate()
@@ -238,7 +231,9 @@ private Deployment makeDesiredDeployment(
     return desiredDeployment;
   }
 
-  private ConfigMap makeDesiredHtmlConfigMap(String ns, String configMapName, WebPage webPage) {
+  private ConfigMap makeDesiredHtmlConfigMap(WebPage webPage) {
+    final var ns = webPage.getMetadata().getNamespace();
+    final var configMapName = configMapName(webPage);
     Map<String, String> data = new HashMap<>();
     data.put(INDEX_HTML, webPage.getSpec().getHtml());
     ConfigMap configMap =