fix

Signed-off-by: Attila Mészáros <[email protected]>

Author: csviri

src/main/java/io/javaoperatorsdk/operator/glue/dependent/GenericDependentResource.java

@@ -4,6 +4,9 @@
 import java.util.Optional;
 import java.util.Set;
 
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
 import io.fabric8.kubernetes.api.model.GenericKubernetesResource;
 import io.fabric8.kubernetes.client.utils.Serialization;
 import io.javaoperatorsdk.operator.api.reconciler.Context;
@@ -24,6 +27,8 @@ public class GenericDependentResource
     Updater<GenericKubernetesResource, Glue>,
     Creator<GenericKubernetesResource, Glue> {
 
+  private static final Logger log = LoggerFactory.getLogger(GenericDependentResource.class);
+
   protected final GenericKubernetesResource desired;
   protected final String desiredTemplate;
   protected final String name;
@@ -104,7 +109,15 @@ protected Optional<GenericKubernetesResource> selectTargetSecondaryResource(
       Glue primary,
       Context<Glue> context) {
 
-    var res = context.getSecondaryResources(GenericKubernetesResource.class)
+    var allSecondaryResources = context.getSecondaryResources(GenericKubernetesResource.class);
+    if (log.isDebugEnabled()) {
+      log.debug("All secondary resources for DR: {}, resources: {}", name,
+          allSecondaryResources.stream()
+              .map(r -> "{ Name: %s; Namespace: %s }".formatted(r.getMetadata().getName(),
+                  r.getMetadata().getNamespace()))
+              .toList());
+    }
+    var res = allSecondaryResources
         .stream()
         .filter(r -> r.getKind().equals(getGroupVersionKind().getKind()) &&
             r.getApiVersion().equals(getGroupVersionKind().apiVersion()) &&

src/main/java/io/javaoperatorsdk/operator/glue/reconciler/glue/GlueReconciler.java

@@ -27,6 +27,8 @@
 import io.javaoperatorsdk.operator.glue.reconciler.ValidationAndStatusHandler;
 import io.javaoperatorsdk.operator.glue.reconciler.operator.GlueOperatorReconciler;
 import io.javaoperatorsdk.operator.glue.templating.GenericTemplateHandler;
+import io.javaoperatorsdk.operator.processing.GroupVersionKind;
+import io.javaoperatorsdk.operator.processing.dependent.kubernetes.GroupVersionKindPlural;
 import io.javaoperatorsdk.operator.processing.dependent.workflow.Condition;
 import io.javaoperatorsdk.operator.processing.dependent.workflow.KubernetesResourceDeletedCondition;
 import io.javaoperatorsdk.operator.processing.dependent.workflow.WorkflowBuilder;
@@ -199,7 +201,11 @@ private void createAndAddDependentToWorkflow(Glue primary, Context<Glue> context
     var name = genericTemplateHandler.processTemplate(Utils.getName(spec), primary, false, context);
     var dr = createDependentResource(name, spec, leafDependent, resourceInSameNamespaceAsPrimary,
         targetNamespace.orElse(null));
-    var gvk = dr.getGroupVersionKind();
+    GroupVersionKind gvk = dr.getGroupVersionKind();
+    // remove when fixed in josdk
+    if (gvk instanceof GroupVersionKindPlural gvkp) {
+      gvk = new GroupVersionKind(gvkp.getGroup(), gvkp.getVersion(), gvkp.getKind());
+    }
 
     var es = informerRegister.registerInformer(context, gvk, primary);
     dr.setEventSource(es);

src/main/java/io/javaoperatorsdk/operator/glue/reconciler/glue/InformerRegister.java

@@ -105,9 +105,11 @@ public InformerEventSource<GenericKubernetesResource, Glue> registerInformer(
 
     var newInformer = informerProducer.createInformer(configBuilder.build(), context);
     log.debug("Registering informer for gvk: {}", gvk);
-    return (InformerEventSource<GenericKubernetesResource, Glue>) context
+    var resultInformer = (InformerEventSource<GenericKubernetesResource, Glue>) context
         .eventSourceRetriever()
         .dynamicallyRegisterEventSource(newInformer);
+    log.debug("Actual new informer registered: {}", resultInformer == newInformer);
+    return resultInformer;
   }
 
   public synchronized void deRegisterInformer(GroupVersionKind groupVersionKind,