feat: automatically derive the the dependent resource type if not specified

Signed-off-by: xstefank <[email protected]>

Author: xstefank

bootstrapper-maven-plugin/src/main/resources/templates/ConfigMapDependentResource.java

@@ -17,10 +17,6 @@ public class ConfigMapDependentResource
 
     public static final String KEY = "key";
 
-    public ConfigMapDependentResource() {
-        super(ConfigMap.class);
-    }
-
     @Override
     protected ConfigMap desired({{artifactClassId}}CustomResource primary,
                                 Context<{{artifactClassId}}CustomResource> context) {

docs/content/en/docs/documentation/dependent-resource-and-workflows/dependent-resources.md

@@ -136,10 +136,6 @@ Deleted (or set to be garbage collected). The following example shows how to cre
 @KubernetesDependent(labelSelector = WebPageManagedDependentsReconciler.SELECTOR)
 class DeploymentDependentResource extends CRUDKubernetesDependentResource<Deployment, WebPage> {
 
-    public DeploymentDependentResource() {
-        super(Deployment.class);
-    }
-
     @Override
     protected Deployment desired(WebPage webPage, Context<WebPage> context) {
         var deploymentName = deploymentName(webPage);

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

@@ -134,6 +134,27 @@ public static Class<?> getTypeArgumentFromExtendedClassByIndex(Class<?> clazz, i
     }
   }
 
+  public static Class<?> getTypeArgumentFromHierarchyByIndex(
+      Class<?> clazz, Class<?> expectedImplementedInterface, int index) {
+    Class<?> c = clazz;
+    while (!(c.getGenericSuperclass() instanceof ParameterizedType)) {
+      c = c.getSuperclass();
+    }
+    Class<?> actualTypeArgument =
+        (Class<?>) ((ParameterizedType) c.getGenericSuperclass()).getActualTypeArguments()[index];
+    if (!expectedImplementedInterface.isAssignableFrom(actualTypeArgument)) {
+      throw new IllegalArgumentException(
+          GENERIC_PARAMETER_TYPE_ERROR_PREFIX
+              + clazz.getName()
+              + "because it doesn't extend a class that is parametrized with the type that"
+              + " implements "
+              + expectedImplementedInterface.getSimpleName()
+              + ". Please provide the resource type in the constructor (e.g.,"
+              + " super(Deployment.class).");
+    }
+    return actualTypeArgument;
+  }
+
   public static Class<?> getFirstTypeArgumentFromInterface(
       Class<?> clazz, Class<?> expectedImplementedInterface) {
     return getTypeArgumentFromInterfaceByIndex(clazz, expectedImplementedInterface, 0);

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

@@ -1,8 +1,10 @@
 package io.javaoperatorsdk.operator.processing.dependent;
 
+import java.lang.reflect.ParameterizedType;
 import java.util.Optional;
 
 import io.fabric8.kubernetes.api.model.HasMetadata;
+import io.javaoperatorsdk.operator.api.config.Utils;
 import io.javaoperatorsdk.operator.api.reconciler.Context;
 import io.javaoperatorsdk.operator.api.reconciler.EventSourceContext;
 import io.javaoperatorsdk.operator.api.reconciler.Ignore;
@@ -23,13 +25,23 @@ public abstract class AbstractEventSourceHolderDependentResource<
   private boolean isCacheFillerEventSource;
   protected String eventSourceNameToUse;
 
+  @SuppressWarnings("unchecked")
+  protected AbstractEventSourceHolderDependentResource() {
+    this(null, null);
+  }
+
   protected AbstractEventSourceHolderDependentResource(Class<R> resourceType) {
     this(resourceType, null);
   }
 
   protected AbstractEventSourceHolderDependentResource(Class<R> resourceType, String name) {
     super(name);
-    this.resourceType = resourceType;
+    if (resourceType == null) {
+      this.resourceType =
+          (Class<R>) Utils.getTypeArgumentFromHierarchyByIndex(getClass(), HasMetadata.class, 0);
+    } else {
+      this.resourceType = resourceType;
+    }
   }
 
   /**
@@ -116,4 +128,23 @@ protected void onUpdated(P primary, R updated, R actual, Context<P> context) {
   private RecentOperationCacheFiller<R> recentOperationCacheFiller() {
     return (RecentOperationCacheFiller<R>) eventSource;
   }
+
+  @SuppressWarnings("unchecked")
+  private Class<R> findFirstGenericSuperclass(
+      Class<? extends AbstractEventSourceHolderDependentResource> clazz) {
+    Class<? extends AbstractEventSourceHolderDependentResource> c = clazz;
+    while (!(c.getGenericSuperclass() instanceof ParameterizedType)) {
+      c = (Class<? extends AbstractEventSourceHolderDependentResource>) c.getSuperclass();
+    }
+    Class<R> actualTypeArgument =
+        (Class<R>) ((ParameterizedType) c.getGenericSuperclass()).getActualTypeArguments()[0];
+    if (!HasMetadata.class.isAssignableFrom(actualTypeArgument)) {
+      throw new IllegalStateException(
+          "Not possible to automatically derive the the resource type for "
+              + clazz.getName()
+              + ". Please provide the resource type in the constructor (e.g.,"
+              + " super(Deployment.class).");
+    }
+    return actualTypeArgument;
+  }
 }

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

@@ -21,6 +21,8 @@ public abstract class AbstractExternalDependentResource<
 
   private InformerEventSource<?, P> externalStateEventSource;
 
+  protected AbstractExternalDependentResource() {}
+
   @SuppressWarnings("unchecked")
   protected AbstractExternalDependentResource(Class<R> resourceType) {
     super(resourceType);

operator-framework-core/src/main/java/io/javaoperatorsdk/operator/processing/dependent/external/AbstractPollingDependentResource.java

@@ -16,6 +16,8 @@ public abstract class AbstractPollingDependentResource<R, P extends HasMetadata>
   public static final Duration DEFAULT_POLLING_PERIOD = Duration.ofMillis(5000);
   private Duration pollingPeriod;
 
+  protected AbstractPollingDependentResource() {}
+
   protected AbstractPollingDependentResource(Class<R> resourceType) {
     this(resourceType, DEFAULT_POLLING_PERIOD);
   }

operator-framework-core/src/main/java/io/javaoperatorsdk/operator/processing/dependent/external/PerResourcePollingDependentResource.java

@@ -14,6 +14,8 @@ public abstract class PerResourcePollingDependentResource<R, P extends HasMetada
     extends AbstractPollingDependentResource<R, P>
     implements PerResourcePollingEventSource.ResourceFetcher<R, P> {
 
+  public PerResourcePollingDependentResource() {}
+
   public PerResourcePollingDependentResource(Class<R> resourceType) {
     super(resourceType);
   }

operator-framework-core/src/main/java/io/javaoperatorsdk/operator/processing/dependent/kubernetes/CRUDKubernetesDependentResource.java

@@ -18,6 +18,8 @@ public abstract class CRUDKubernetesDependentResource<R extends HasMetadata, P e
     extends KubernetesDependentResource<R, P>
     implements Creator<R, P>, Updater<R, P>, GarbageCollected<P> {
 
+  public CRUDKubernetesDependentResource() {}
+
   public CRUDKubernetesDependentResource(Class<R> resourceType) {
     super(resourceType);
   }

operator-framework-core/src/main/java/io/javaoperatorsdk/operator/processing/dependent/kubernetes/CRUDNoGCKubernetesDependentResource.java

@@ -20,6 +20,8 @@
 public class CRUDNoGCKubernetesDependentResource<R extends HasMetadata, P extends HasMetadata>
     extends KubernetesDependentResource<R, P> implements Creator<R, P>, Updater<R, P>, Deleter<P> {
 
+  public CRUDNoGCKubernetesDependentResource() {}
+
   public CRUDNoGCKubernetesDependentResource(Class<R> resourceType) {
     super(resourceType);
   }

operator-framework-core/src/main/java/io/javaoperatorsdk/operator/processing/dependent/kubernetes/KubernetesDependentResource.java

@@ -41,6 +41,8 @@ public abstract class KubernetesDependentResource<R extends HasMetadata, P exten
   private KubernetesDependentResourceConfig<R> kubernetesDependentResourceConfig;
   private volatile Boolean useSSA;
 
+  public KubernetesDependentResource() {}
+
   public KubernetesDependentResource(Class<R> resourceType) {
     this(resourceType, null);
   }