wip

Signed-off-by: Attila Mészáros <a_meszaros@apple.com>

Author: csviri

operator-framework-core/src/main/java/io/javaoperatorsdk/operator/processing/event/source/informer/TemporaryResourceCache.java

@@ -188,11 +188,12 @@ public synchronized void putResource(T newResource) {
       return;
     }
 
+    var ns = newResource.getMetadata().getNamespace();
     // todo unit test
     // this can happen when we dynamically change the NS
-    if (!managedInformerEventSource
-        .manager()
-        .isWatchingNamespace(newResource.getMetadata().getNamespace())) {
+    if (!managedInformerEventSource.manager().isWatchingNamespace(ns)) {
+      log.debug(
+          "Skipping caching of resource: {} since namespace is now watched: {}", resourceId, ns);
       return;
     }
 
@@ -201,7 +202,7 @@ public synchronized void putResource(T newResource) {
     //
     // this also prevents resurrecting recently deleted entities for which the delete event
     // has already been processed
-    var latestRV = getLastSyncResourceVersion(newResource.getMetadata().getNamespace());
+    var latestRV = getLastSyncResourceVersion(ns);
     if (latestRV != null
         && ReconcilerUtilsInternal.compareResourceVersions(
                 latestRV, newResource.getMetadata().getResourceVersion())

operator-framework-core/src/test/java/io/javaoperatorsdk/operator/processing/event/source/informer/TemporaryPrimaryResourceCacheTest.java

@@ -58,6 +58,7 @@ void setup() {
     managedInformerEventSource = mock(ManagedInformerEventSource.class);
     var mim = mock(InformerManager.class);
     when(managedInformerEventSource.manager()).thenReturn(mim);
+    when(mim.isWatchingNamespace(any())).thenReturn(true);
     when(mim.lastSyncResourceVersion(any())).then(a -> latestSyncVersion);
     temporaryResourceCache =
         new TemporaryResourceCache<>(

operator-framework/src/test/java/io/javaoperatorsdk/operator/dependent/dependentdifferentnamespace/ConfigMapDependentResource.java

@@ -19,9 +19,13 @@
 
 import io.fabric8.kubernetes.api.model.ConfigMap;
 import io.fabric8.kubernetes.api.model.ObjectMeta;
+import io.javaoperatorsdk.operator.api.config.informer.Informer;
+import io.javaoperatorsdk.operator.api.reconciler.Constants;
 import io.javaoperatorsdk.operator.api.reconciler.Context;
 import io.javaoperatorsdk.operator.processing.dependent.kubernetes.CRUDNoGCKubernetesDependentResource;
+import io.javaoperatorsdk.operator.processing.dependent.kubernetes.KubernetesDependent;
 
+@KubernetesDependent(informer = @Informer(namespaces = Constants.WATCH_ALL_NAMESPACES))
 public class ConfigMapDependentResource
     extends CRUDNoGCKubernetesDependentResource<
         ConfigMap, DependentDifferentNamespaceCustomResource> {