Updated informer mapper

Author: csviri

operator-framework-core/src/main/java/io/javaoperatorsdk/operator/processing/event/internal/InformerEventSource.java

@@ -1,7 +1,7 @@
 package io.javaoperatorsdk.operator.processing.event.internal;
 
 import java.io.IOException;
-import java.util.Optional;
+import java.util.List;
 
 import io.fabric8.kubernetes.api.model.HasMetadata;
 import io.fabric8.kubernetes.client.KubernetesClient;
@@ -64,12 +64,14 @@ public void onDelete(T t, boolean b) {
   }
 
   private void propagateEvent(InformerEvent.Action action, T object, T oldObject) {
-    var uid = mapper.map(object);
-    if (uid.isEmpty()) {
+    var uids = mapper.map(object);
+    if (uids.isEmpty()) {
       return;
     }
-    InformerEvent event = new InformerEvent(uid.get(), this, action, object, oldObject);
-    this.eventHandler.handleEvent(event);
+    uids.forEach(uid -> {
+      InformerEvent event = new InformerEvent(uid, this, action, object, oldObject);
+      this.eventHandler.handleEvent(event);
+    });
   }
 
   @Override
@@ -91,8 +93,7 @@ public SharedInformer<T> getSharedInformer() {
   }
 
   public interface ResourceToRelatedCustomResourceUIDMapper<T> {
-    // in case cannot map to the related CR uid, skip the event processing
-    Optional<String> map(T resource);
+    List<String> map(T resource);
   }
 
 }

operator-framework/src/test/java/io/javaoperatorsdk/operator/sample/informereventsource/InformerEventSourceTestCustomResourceController.java

@@ -1,6 +1,7 @@
 package io.javaoperatorsdk.operator.sample.informereventsource;
 
-import java.util.Optional;
+import java.util.Arrays;
+import java.util.Collections;
 
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
@@ -44,10 +45,9 @@ public void init(EventSourceManager eventSourceManager) {
     eventSourceManager.registerEventSource("configmap", new InformerEventSource<>(informer,
         resource -> {
           if (resource.getMetadata() == null || resource.getMetadata().getAnnotations() == null) {
-            return Optional.empty();
+            return Collections.emptyList();
           }
-          return Optional
-              .ofNullable(resource.getMetadata().getAnnotations().get(RELATED_RESOURCE_UID));
+          return Arrays.asList(resource.getMetadata().getAnnotations().get(RELATED_RESOURCE_UID));
         }));
   }