fix null event source manager from context

Author: csviri

operator-framework/src/main/java/io/javaoperatorsdk/operator/Operator.java

@@ -61,6 +61,7 @@ private <R extends CustomResource> void registerController(ResourceController<R>
         DefaultEventHandler defaultEventHandler = new DefaultEventHandler(resourceCache, eventDispatcher, controller.getClass().getName());
         DefaultEventSourceManager eventSourceManager = new DefaultEventSourceManager(defaultEventHandler);
         defaultEventHandler.setDefaultEventSourceManager(eventSourceManager);
+        eventDispatcher.setEventSourceManager(eventSourceManager);
 
         customResourceClients.put(resClass, (CustomResourceOperationsImpl) client);
 

operator-framework/src/main/java/io/javaoperatorsdk/operator/api/DefaultContext.java

@@ -8,21 +8,22 @@
 
 public class DefaultContext<T extends CustomResource> implements Context<T> {
 
-    private final CustomResource customResource;
     private final List<Event> events;
+    private final EventSourceManager eventSourceManager;
 
-    public DefaultContext(CustomResource customResource, List<Event> events) {
-        this.customResource = customResource;
+    public DefaultContext(EventSourceManager eventSourceManager, List<Event> events) {
         this.events = events;
+        this.eventSourceManager = eventSourceManager;
     }
 
     @Override
     public EventSourceManager getEventSourceManager() {
-        return null;
+        return eventSourceManager;
     }
 
     @Override
     public List<Event> getEvents() {
-        return null;
+        return events;
     }
+
 }

operator-framework/src/main/java/io/javaoperatorsdk/operator/processing/EventDispatcher.java

@@ -6,6 +6,7 @@
 import io.fabric8.kubernetes.client.dsl.Resource;
 import io.javaoperatorsdk.operator.api.*;
 import io.javaoperatorsdk.operator.processing.event.Event;
+import io.javaoperatorsdk.operator.processing.event.EventSourceManager;
 import io.javaoperatorsdk.operator.processing.event.internal.CustomResourceEvent;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
@@ -28,6 +29,7 @@ public class EventDispatcher {
     private final CustomResourceFacade customResourceFacade;
     private final boolean generationAware;
     private final Map<String, Long> lastGenerationProcessedSuccessfully = new ConcurrentHashMap<>();
+    private EventSourceManager eventSourceManager;
 
     public EventDispatcher(ResourceController controller,
                            String finalizer,
@@ -38,6 +40,10 @@ public EventDispatcher(ResourceController controller,
         this.generationAware = generationAware;
     }
 
+    public void setEventSourceManager(EventSourceManager eventSourceManager) {
+        this.eventSourceManager = eventSourceManager;
+    }
+
     public PostExecutionControl handleEvent(ExecutionScope event) {
         try {
             return handDispatch(event);
@@ -61,7 +67,7 @@ private PostExecutionControl handDispatch(ExecutionScope executionScope) {
             log.debug("Skipping event dispatching since its marked for deletion but has no finalizer: {}", executionScope);
             return PostExecutionControl.defaultDispatch();
         }
-        Context context = new DefaultContext(executionScope.getCustomResource(), executionScope.getEvents());
+        Context context = new DefaultContext(eventSourceManager, executionScope.getEvents());
         if (markedForDeletion(resource)) {
             return handleDelete(resource, context);
         } else {