refactor: clean-up (#2325)

Signed-off-by: Chris Laprun <claprun@redhat.com>
Co-authored-by: Attila Mészáros <csviri@gmail.com>

Author: metacosm

bootstrapper-maven-plugin/src/main/java/io/javaoperatorsdk/boostrapper/Bootstrapper.java

@@ -21,7 +21,7 @@ public class Bootstrapper {
 
   private static final Logger log = LoggerFactory.getLogger(Bootstrapper.class);
 
-  private MustacheFactory mustacheFactory = new DefaultMustacheFactory();
+  private final MustacheFactory mustacheFactory = new DefaultMustacheFactory();
 
   private static final List<String> TOP_LEVEL_STATIC_FILES =
       List.of(".gitignore", "README.md");

docs/documentation/workflows.md

@@ -133,7 +133,7 @@ public class WebPageDependentsWorkflowReconciler
   private KubernetesDependentResource<Service, WebPage> serviceDR;
   private KubernetesDependentResource<Ingress, WebPage> ingressDR;
 
-  private Workflow<WebPage> workflow;
+  private final Workflow<WebPage> workflow;
 
   public WebPageDependentsWorkflowReconciler(KubernetesClient kubernetesClient) {
     initDependentResources(kubernetesClient);

operator-framework-core/src/main/java/io/javaoperatorsdk/operator/BuilderUtils.java

@@ -10,7 +10,7 @@ public final class BuilderUtils {
   // prevent instantiation of util class
   private BuilderUtils() {}
 
-  public static final <T, B> B newBuilder(Class<B> builderType, T item) {
+  public static <T, B> B newBuilder(Class<B> builderType, T item) {
     Class<T> builderTargetType = builderTargetType(builderType);
     try {
       Constructor<B> constructor = builderType.getDeclaredConstructor(builderTargetType);

operator-framework-core/src/main/java/io/javaoperatorsdk/operator/ReconcilerUtils.java

@@ -9,7 +9,6 @@
 import java.util.Objects;
 import java.util.function.Predicate;
 import java.util.regex.Pattern;
-import java.util.stream.Collectors;
 
 import io.fabric8.kubernetes.api.builder.Builder;
 import io.fabric8.kubernetes.api.model.GenericKubernetesResource;
@@ -126,8 +125,7 @@ public static boolean specsEqual(HasMetadata r1, HasMetadata r2) {
   // will be replaced with: https://github.com/fabric8io/kubernetes-client/issues/3816
   public static Object getSpec(HasMetadata resource) {
     // optimize CustomResource case
-    if (resource instanceof CustomResource) {
-      CustomResource cr = (CustomResource) resource;
+    if (resource instanceof CustomResource cr) {
       return cr.getSpec();
     }
 
@@ -142,8 +140,7 @@ public static Object getSpec(HasMetadata resource) {
   @SuppressWarnings("unchecked")
   public static Object setSpec(HasMetadata resource, Object spec) {
     // optimize CustomResource case
-    if (resource instanceof CustomResource) {
-      CustomResource cr = (CustomResource) resource;
+    if (resource instanceof CustomResource cr) {
       cr.setSpec(spec);
       return null;
     }
@@ -191,8 +188,7 @@ public static void handleKubernetesClientException(Exception e, String resourceT
       throw ((MissingCRDException) e);
     }
 
-    if (e instanceof KubernetesClientException) {
-      KubernetesClientException ke = (KubernetesClientException) e;
+    if (e instanceof KubernetesClientException ke) {
       // only throw MissingCRDException if the 404 error occurs on the target CRD
       if (404 == ke.getCode() &&
           (resourceTypeName.equals(ke.getFullResourceName())
@@ -217,7 +213,7 @@ private static boolean matchesResourceType(String resourceTypeName,
           group = group.substring(0, group.length() - 1);
         }
         final var segments = Arrays.stream(group.split("/")).filter(Predicate.not(String::isEmpty))
-            .collect(Collectors.toUnmodifiableList());
+            .toList();
         if (segments.size() != 3) {
           return false;
         }

operator-framework-core/src/main/java/io/javaoperatorsdk/operator/api/config/BaseConfigurationService.java

@@ -260,8 +260,7 @@ private static <T> Configurator<T> configuratorFor(Class<T> instanceType,
 
   @SuppressWarnings({"unchecked", "rawtypes"})
   private static void configureFromAnnotatedReconciler(Object instance, Reconciler<?> reconciler) {
-    if (instance instanceof AnnotationConfigurable) {
-      AnnotationConfigurable configurable = (AnnotationConfigurable) instance;
+    if (instance instanceof AnnotationConfigurable configurable) {
       final Class<? extends Annotation> configurationClass =
           (Class<? extends Annotation>) Utils.getFirstTypeArgumentFromSuperClassOrInterface(
               instance.getClass(), AnnotationConfigurable.class);

operator-framework-core/src/main/java/io/javaoperatorsdk/operator/api/config/ControllerConfigurationOverrider.java

@@ -10,7 +10,6 @@
 import io.fabric8.kubernetes.api.model.HasMetadata;
 import io.fabric8.kubernetes.client.informers.cache.ItemStore;
 import io.javaoperatorsdk.operator.api.config.dependent.DependentResourceSpec;
-import io.javaoperatorsdk.operator.api.config.workflow.WorkflowSpec;
 import io.javaoperatorsdk.operator.processing.event.rate.RateLimiter;
 import io.javaoperatorsdk.operator.processing.event.source.filter.GenericFilter;
 import io.javaoperatorsdk.operator.processing.event.source.filter.OnAddFilter;
@@ -39,7 +38,6 @@ public class ControllerConfigurationOverrider<R extends HasMetadata> {
   private String name;
   private String fieldManager;
   private Long informerListLimit;
-  private WorkflowSpec workflowSpec;
 
   private ControllerConfigurationOverrider(ControllerConfiguration<R> original) {
     this.finalizer = original.getFinalizerName();
@@ -57,7 +55,6 @@ private ControllerConfigurationOverrider(ControllerConfiguration<R> original) {
     this.fieldManager = original.fieldManager();
     this.informerListLimit = original.getInformerListLimit().orElse(null);
     this.itemStore = original.getItemStore().orElse(null);
-    this.workflowSpec = original.getWorkflowSpec().orElse(null);
   }
 
   public ControllerConfigurationOverrider<R> withFinalizer(String finalizer) {

operator-framework-core/src/main/java/io/javaoperatorsdk/operator/api/config/LeaderElectionConfigurationBuilder.java

@@ -6,9 +6,10 @@
 
 import static io.javaoperatorsdk.operator.api.config.LeaderElectionConfiguration.*;
 
+@SuppressWarnings("unused")
 public final class LeaderElectionConfigurationBuilder {
 
-  private String leaseName;
+  private final String leaseName;
   private String leaseNamespace;
   private String identity;
   private Duration leaseDuration = LEASE_DURATION_DEFAULT_VALUE;

operator-framework-core/src/main/java/io/javaoperatorsdk/operator/api/config/ResolvedControllerConfiguration.java

@@ -1,7 +1,10 @@
 package io.javaoperatorsdk.operator.api.config;
 
 import java.time.Duration;
-import java.util.*;
+import java.util.Collections;
+import java.util.Map;
+import java.util.Optional;
+import java.util.Set;
 import java.util.concurrent.TimeUnit;
 
 import io.fabric8.kubernetes.api.model.HasMetadata;
@@ -105,7 +108,6 @@ protected ResolvedControllerConfiguration(Class<P> resourceClass, String name,
     this.finalizer =
         ControllerConfiguration.ensureValidFinalizerName(finalizer, getResourceTypeName());
     this.fieldManager = fieldManager;
-    this.workflowSpec = workflowSpec;
   }
 
   protected ResolvedControllerConfiguration(Class<P> resourceClass, String name,

operator-framework-core/src/main/java/io/javaoperatorsdk/operator/api/config/dependent/DependentResourceConfigurationResolver.java

@@ -22,8 +22,7 @@ private DependentResourceConfigurationResolver() {}
 
   public static <C extends ControllerConfiguration<? extends HasMetadata>> void configure(
       DependentResource dependentResource, DependentResourceSpec spec, C parentConfiguration) {
-    if (dependentResource instanceof DependentResourceConfigurator) {
-      final var configurator = (DependentResourceConfigurator) dependentResource;
+    if (dependentResource instanceof DependentResourceConfigurator configurator) {
       final var config = configurationFor(spec, parentConfiguration);
       configurator.configureWith(config);
     }
@@ -33,8 +32,7 @@ public static <C extends ControllerConfiguration<? extends HasMetadata>> Object
       DependentResourceSpec spec, C parentConfiguration) {
 
     // first check if the parent configuration has potentially already resolved the configuration
-    if (parentConfiguration instanceof DependentResourceConfigurationProvider) {
-      final var provider = (DependentResourceConfigurationProvider) parentConfiguration;
+    if (parentConfiguration instanceof DependentResourceConfigurationProvider provider) {
       final var configuration = provider.getConfigurationFor(spec);
       if (configuration != null) {
         return configuration;

operator-framework-core/src/main/java/io/javaoperatorsdk/operator/processing/Controller.java

@@ -239,8 +239,7 @@ public void initAndRegisterEventSources(EventSourceContext<P> context) {
     final var size = dependentResourcesByName.size();
     if (size > 0) {
       dependentResourcesByName.forEach((key, dependentResource) -> {
-        if (dependentResource instanceof EventSourceProvider) {
-          final var provider = (EventSourceProvider) dependentResource;
+        if (dependentResource instanceof EventSourceProvider provider) {
           final var source = provider.initEventSource(context);
           eventSourceManager.registerEventSource(key, source);
         } else {