initiate resolver in init method

Author: Soroosh Sarabadani

operator-framework/src/main/java/io/javaoperatorsdk/operator/processing/annotation/ControllerAnnotationProcessor.java

@@ -16,11 +16,9 @@
 import io.fabric8.kubernetes.client.CustomResourceDoneable;
 import io.javaoperatorsdk.operator.api.ResourceController;
 import java.io.PrintWriter;
-import java.util.ArrayList;
 import java.util.HashSet;
 import java.util.List;
 import java.util.Set;
-import java.util.stream.Collectors;
 import java.util.stream.IntStream;
 import javax.annotation.processing.AbstractProcessor;
 import javax.annotation.processing.ProcessingEnvironment;
@@ -36,7 +34,6 @@
 import javax.lang.model.element.TypeElement;
 import javax.lang.model.element.TypeParameterElement;
 import javax.lang.model.type.DeclaredType;
-import javax.lang.model.type.TypeKind;
 import javax.lang.model.type.TypeMirror;
 import javax.lang.model.type.TypeVariable;
 import javax.tools.Diagnostic;
@@ -49,16 +46,7 @@ public class ControllerAnnotationProcessor extends AbstractProcessor {
 
   private AccumulativeMappingWriter controllersResourceWriter;
   private AccumulativeMappingWriter doneablesResourceWriter;
-  final DeclaredType resourceControllerType =
-      processingEnv
-          .getTypeUtils()
-          .getDeclaredType(
-              processingEnv
-                  .getElementUtils()
-                  .getTypeElement(ResourceController.class.getCanonicalName()),
-              processingEnv.getTypeUtils().getWildcardType(null, null));
-  private final TypeParameterResolver typeParameterResolver = new TypeParameterResolver(
-      resourceControllerType, 0);
+  private TypeParameterResolver typeParameterResolver;
   private final Set<String> generatedDoneableClassFiles = new HashSet<>();
 
   @Override
@@ -70,6 +58,16 @@ public synchronized void init(ProcessingEnvironment processingEnv) {
     doneablesResourceWriter =
         new AccumulativeMappingWriter(DONEABLES_RESOURCE_PATH, processingEnv)
             .loadExistingMappings();
+
+    final DeclaredType resourceControllerType =
+        processingEnv
+            .getTypeUtils()
+            .getDeclaredType(
+                processingEnv
+                    .getElementUtils()
+                    .getTypeElement(ResourceController.class.getCanonicalName()),
+                processingEnv.getTypeUtils().getWildcardType(null, null));
+    typeParameterResolver = new TypeParameterResolver(resourceControllerType, 0);
   }
 
   @Override
@@ -157,8 +155,10 @@ private void generateDoneableClass(TypeElement controllerClassSymbol) {
 
   private TypeMirror findResourceType(TypeElement controllerClassSymbol) throws Exception {
     try {
-      final var chain = typeParameterResolver
-          .findChain(processingEnv.getTypeUtils(), processingEnv.getElementUtils(),
+      final var chain =
+          typeParameterResolver.findChain(
+              processingEnv.getTypeUtils(),
+              processingEnv.getElementUtils(),
               (DeclaredType) controllerClassSymbol.asType());
       final var customResourceClass = getCustomResourceClass(chain);
       return customResourceClass;

operator-framework/src/main/java/io/javaoperatorsdk/operator/processing/annotation/TypeParameterResolver.java

@@ -20,9 +20,8 @@ public TypeParameterResolver(DeclaredType interestedClass, int interestedTypeArg
     this.interestedTypeArgumentIndex = interestedTypeArgumentIndex;
   }
 
-
-  public List<DeclaredType> findChain(Types typeUtils, Elements elementUtils,
-      DeclaredType declaredType) {
+  public List<DeclaredType> findChain(
+      Types typeUtils, Elements elementUtils, DeclaredType declaredType) {
 
     final var result = new ArrayList<DeclaredType>();
     result.add(declaredType);
@@ -31,9 +30,7 @@ public List<DeclaredType> findChain(Types typeUtils, Elements elementUtils,
     boolean interfaceFound = false;
     final var matchingInterfaces =
         superElement.getInterfaces().stream()
-            .filter(
-                intface ->
-                    typeUtils.isAssignable(intface, interestedClass))
+            .filter(intface -> typeUtils.isAssignable(intface, interestedClass))
             .map(i -> (DeclaredType) i)
             .collect(Collectors.toList());
     if (!matchingInterfaces.isEmpty()) {
@@ -47,12 +44,9 @@ public List<DeclaredType> findChain(Types typeUtils, Elements elementUtils,
         final var marchingInterfaces =
             ((TypeElement) lastFoundInterface.asElement())
                 .getInterfaces().stream()
-                .filter(
-                    intface ->
-                        typeUtils
-                            .isAssignable(intface, interestedClass))
-                .map(i -> (DeclaredType) i)
-                .collect(Collectors.toList());
+                    .filter(intface -> typeUtils.isAssignable(intface, interestedClass))
+                    .map(i -> (DeclaredType) i)
+                    .collect(Collectors.toList());
 
         if (marchingInterfaces.size() > 0) {
           result.addAll(marchingInterfaces);
@@ -69,9 +63,7 @@ public List<DeclaredType> findChain(Types typeUtils, Elements elementUtils,
       superElement = (TypeElement) superclass.asElement();
       final var matchedInterfaces =
           superElement.getInterfaces().stream()
-              .filter(
-                  intface ->
-                      typeUtils.isAssignable(intface, interestedClass))
+              .filter(intface -> typeUtils.isAssignable(intface, interestedClass))
               .map(i -> (DeclaredType) i)
               .collect(Collectors.toList());
       if (matchedInterfaces.size() > 0) {
@@ -88,5 +80,4 @@ public List<DeclaredType> findChain(Types typeUtils, Elements elementUtils,
 
     return result;
   }
-
 }