improve: test getting secondary resource directly after filtering caching update

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

Author: csviri

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

@@ -24,6 +24,7 @@
 import org.junit.jupiter.api.Test;
 
 import io.fabric8.kubernetes.api.model.ObjectMeta;
+import io.fabric8.kubernetes.api.model.ObjectMetaBuilder;
 import io.fabric8.kubernetes.api.model.apps.Deployment;
 import io.fabric8.kubernetes.api.model.apps.DeploymentBuilder;
 import io.fabric8.kubernetes.client.KubernetesClient;
@@ -74,14 +75,16 @@ class InformerEventSourceTest {
   private final EventHandler eventHandlerMock = mock(EventHandler.class);
   private final InformerEventSourceConfiguration<Deployment> informerEventSourceConfiguration =
       mock(InformerEventSourceConfiguration.class);
+  private SecondaryToPrimaryMapper mockSecondaryToPrimaryMapper =
+      mock(SecondaryToPrimaryMapper.class);
 
   @BeforeEach
   void setup() {
     final var informerConfig = mock(InformerConfiguration.class);
     when(informerEventSourceConfiguration.getInformerConfig()).thenReturn(informerConfig);
     when(informerConfig.getEffectiveNamespaces(any())).thenReturn(DEFAULT_NAMESPACES_SET);
     when(informerEventSourceConfiguration.getSecondaryToPrimaryMapper())
-        .thenReturn(mock(SecondaryToPrimaryMapper.class));
+        .thenReturn(mockSecondaryToPrimaryMapper);
     when(informerEventSourceConfiguration.getResourceClass()).thenReturn(Deployment.class);
 
     informerEventSource =
@@ -90,6 +93,11 @@ void setup() {
               // mocking start
               @Override
               public synchronized void start() {}
+
+              @Override
+              public Optional<Deployment> get(ResourceID resourceID) {
+                return temporaryResourceCache.getResourceFromCache(resourceID);
+              }
             });
 
     var mockControllerConfig = mock(ControllerConfiguration.class);
@@ -338,6 +346,30 @@ void multipleCachingFilteringUpdates_variant4() {
     assertNoEventProduced();
   }
 
+  @Test
+  void cachingFilteringUpdateEventUpdatesPrimaryToSecondaryIndex() {
+    withRealTemporaryResourceCache();
+    var td = testDeployment();
+    when(mockSecondaryToPrimaryMapper.toPrimaryResourceIDs(any()))
+        .thenReturn(Set.of(ResourceID.fromResource(td)));
+
+    informerEventSource.eventFilteringUpdateAndCacheResource(
+        td,
+        d -> {
+          var d1 = testDeployment();
+          d1.getMetadata().setResourceVersion("2");
+          return d1;
+        });
+
+    var cr = new TestCustomResource();
+    cr.setMetadata(
+        new ObjectMetaBuilder()
+            .withName(td.getMetadata().getName())
+            .withNamespace(td.getMetadata().getNamespace())
+            .build());
+    assertThat(informerEventSource.getSecondaryResources(cr)).isNotEmpty();
+  }
+
   private void assertNoEventProduced() {
     await()
         .pollDelay(Duration.ofMillis(50))