fix

Signed-off-by: Attila Mészáros <[email protected]>

Author: csviri

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

@@ -21,8 +21,8 @@ class EventSources<P extends HasMetadata> {
       new ConcurrentSkipListMap<>();
   private final Map<String, EventSource> sourceByName = new HashMap<>();
 
-    private final TimerEventSource<P> retryAndRescheduleTimerEventSource =
-            new TimerEventSource<>("RetryAndRescheduleTimerEventSource");
+  private final TimerEventSource<P> retryAndRescheduleTimerEventSource =
+      new TimerEventSource<>("RetryAndRescheduleTimerEventSource");
   private ControllerEventSource<P> controllerEventSource;
 
   public void add(EventSource eventSource) {

operator-framework-core/src/test/java/io/javaoperatorsdk/operator/processing/event/EventSourceManagerTest.java

@@ -49,8 +49,11 @@ public void registersEventSource() {
   public void closeShouldCascadeToEventSources() {
     EventSource eventSource = mock(EventSource.class);
     when(eventSource.name()).thenReturn("name1");
+    when(eventSource.resourceType()).thenReturn(EventSource.class);
+
     EventSource eventSource2 = mock(TimerEventSource.class);
     when(eventSource2.name()).thenReturn("name2");
+    when(eventSource2.resourceType()).thenReturn(AbstractEventSource.class);
 
     eventSourceManager.registerEventSource(eventSource);
     eventSourceManager.registerEventSource(eventSource2);
@@ -66,9 +69,11 @@ public void startCascadesToEventSources() {
     EventSource eventSource = mock(EventSource.class);
     when(eventSource.priority()).thenReturn(EventSourceStartPriority.DEFAULT);
     when(eventSource.name()).thenReturn("name1");
+    when(eventSource.resourceType()).thenReturn(EventSource.class);
     EventSource eventSource2 = mock(TimerEventSource.class);
     when(eventSource2.priority()).thenReturn(EventSourceStartPriority.DEFAULT);
     when(eventSource2.name()).thenReturn("name2");
+    when(eventSource2.resourceType()).thenReturn(AbstractEventSource.class);
     eventSourceManager.registerEventSource(eventSource);
     eventSourceManager.registerEventSource(eventSource2);
 

operator-framework-core/src/test/java/io/javaoperatorsdk/operator/processing/event/EventSourcesTest.java

@@ -133,8 +133,8 @@ void getShouldWork() {
     final var mock1 =
         eventSourceMockWithName(EventSource.class, "name1", HasMetadata.class);
     final var mock2 =
-        eventSourceMockWithName(ResourceEventSource.class, "name2", HasMetadata.class);
-    final var mock3 = eventSourceMockWithName(ResourceEventSource.class, "name3", ConfigMap.class);
+        eventSourceMockWithName(EventSource.class, "name2", HasMetadata.class);
+    final var mock3 = eventSourceMockWithName(EventSource.class, "name3", ConfigMap.class);
 
     eventSources.add(mock1);
     eventSources.add(mock2);