fix IT

Author: csviri

caffein-bounded-cache-support/src/test/java/io/javaoperatorsdk/operator/processing/event/source/cache/CaffeinBoundedCacheClusterScopeIT.java

@@ -34,6 +34,7 @@ BoundedCacheClusterScopeTestCustomResource createTestResource(int index) {
         .build());
     res.setSpec(new BoundedCacheTestSpec());
     res.getSpec().setData(INITIAL_DATA_PREFIX + index);
+    res.getSpec().setTargetNamespace(extension.getNamespace());
     return res;
   }
 

caffein-bounded-cache-support/src/test/java/io/javaoperatorsdk/operator/processing/event/source/cache/CaffeinBoundedCacheNamespacedIT.java

@@ -11,9 +11,6 @@
 import io.javaoperatorsdk.operator.processing.event.source.cache.sample.namespacescope.BoundedCacheTestReconciler;
 import io.javaoperatorsdk.operator.processing.event.source.cache.sample.namespacescope.BoundedCacheTestSpec;
 
-import static io.javaoperatorsdk.operator.processing.event.source.cache.BoundedCacheTestBase.INITIAL_DATA_PREFIX;
-import static io.javaoperatorsdk.operator.processing.event.source.cache.BoundedCacheTestBase.RESOURCE_NAME_PREFIX;
-
 class CaffeinBoundedCacheNamespacedIT extends BoundedCacheTestBase<BoundedCacheTestCustomResource> {
 
   @RegisterExtension
@@ -33,6 +30,7 @@ BoundedCacheTestCustomResource createTestResource(int index) {
         .build());
     res.setSpec(new BoundedCacheTestSpec());
     res.getSpec().setData(INITIAL_DATA_PREFIX + index);
+    res.getSpec().setTargetNamespace(extension.getNamespace());
     return res;
   }
 

caffein-bounded-cache-support/src/test/java/io/javaoperatorsdk/operator/processing/event/source/cache/sample/AbstractTestReconciler.java

@@ -20,6 +20,7 @@
 import io.javaoperatorsdk.operator.processing.event.source.cache.sample.namespacescope.BoundedCacheTestSpec;
 import io.javaoperatorsdk.operator.processing.event.source.cache.sample.namespacescope.BoundedCacheTestStatus;
 import io.javaoperatorsdk.operator.processing.event.source.informer.InformerEventSource;
+import io.javaoperatorsdk.operator.processing.event.source.informer.Mappers;
 
 public abstract class AbstractTestReconciler<P extends CustomResource<BoundedCacheTestSpec, BoundedCacheTestStatus>>
     implements KubernetesClientAware, Reconciler<P>,
@@ -58,8 +59,7 @@ protected void createConfigMap(P resource) {
     var cm = new ConfigMapBuilder()
         .withMetadata(new ObjectMetaBuilder()
             .withName(resource.getMetadata().getName())
-            .withNamespace(resource instanceof Namespaced ? resource.getMetadata().getNamespace()
-                : DEFAULT_NAMESPACE)
+            .withNamespace(resource.getSpec().getTargetNamespace())
             .build())
         .withData(Map.of(DATA_KEY, resource.getSpec().getData()))
         .build();
@@ -88,6 +88,8 @@ public Map<String, EventSource> prepareEventSources(
 
     var es = new InformerEventSource<>(InformerConfiguration.from(ConfigMap.class, context)
         .withItemStore(boundedItemStore)
+        .withSecondaryToPrimaryMapper(
+            Mappers.fromOwnerReference(this instanceof BoundedCacheClusterScopeTestReconciler))
         .build(), context);
 
     return EventSourceInitializer.nameEventSources(es);

caffein-bounded-cache-support/src/test/java/io/javaoperatorsdk/operator/processing/event/source/cache/sample/namespacescope/BoundedCacheTestSpec.java

@@ -3,6 +3,7 @@
 public class BoundedCacheTestSpec {
 
   private String data;
+  private String targetNamespace;
 
   public String getData() {
     return data;
@@ -12,4 +13,13 @@ public BoundedCacheTestSpec setData(String data) {
     this.data = data;
     return this;
   }
+
+  public String getTargetNamespace() {
+    return targetNamespace;
+  }
+
+  public BoundedCacheTestSpec setTargetNamespace(String targetNamespace) {
+    this.targetNamespace = targetNamespace;
+    return this;
+  }
 }