improve and add unit test for event processor

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

Author: csviri

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

@@ -390,6 +390,8 @@ void newResourceAfterMissedDeleteEvent() {
 
   @Test
   void rateLimitsReconciliationSubmission() {
+    when(reconciliationDispatcherMock.handleExecution(any()))
+        .thenReturn(PostExecutionControl.defaultDispatch());
     // the refresh defaultPollingPeriod value does not matter here
     var refreshPeriod = Duration.ofMillis(100);
     var event = prepareCREvent();
@@ -403,10 +405,12 @@ void rateLimitsReconciliationSubmission() {
     eventProcessor.handleEvent(event);
     verify(reconciliationDispatcherMock, after(FAKE_CONTROLLER_EXECUTION_DURATION).times(1))
         .handleExecution(any());
-    verify(retryTimerEventSourceMock, times(0)).scheduleOnce((ResourceID) any(), anyLong());
+    verify(retryTimerEventSourceMock, times(0))
+        .scheduleOnce((ResourceID) any(), eq(refreshPeriod.toMillis()));
 
     eventProcessor.handleEvent(event);
-    verify(retryTimerEventSourceMock, times(1)).scheduleOnce((ResourceID) any(), anyLong());
+    verify(retryTimerEventSourceMock, times(1))
+        .scheduleOnce((ResourceID) any(), eq(refreshPeriod.toMillis()));
   }
 
   @Test
@@ -662,6 +666,45 @@ void afterRetryExhaustedAdditionalEventTriggerReconciliationWhenDeleteEventPrese
     verify(reconciliationDispatcherMock, times(4)).handleExecution(any());
   }
 
+  @Test
+  void rateLimitsDeleteEventInAllEventMode() {
+    when(eventSourceManagerMock.retryEventSource()).thenReturn(retryTimerEventSourceMock);
+    when(reconciliationDispatcherMock.handleExecution(any()))
+        .thenReturn(PostExecutionControl.defaultDispatch());
+    eventProcessor =
+        spy(
+            new EventProcessor(
+                controllerConfigTriggerAllEvent(
+                    GenericRetry.defaultLimitedExponentialRetry()
+                        .setInitialInterval(100)
+                        .setIntervalMultiplier(1)
+                        .setMaxAttempts(1),
+                    rateLimiterMock),
+                reconciliationDispatcherMock,
+                eventSourceManagerMock,
+                null));
+    eventProcessor.start();
+    // the refresh defaultPollingPeriod value does not matter here
+    var refreshPeriod = Duration.ofMillis(100);
+    var event = prepareCREvent();
+
+    final var rateLimit = new RateLimitState() {};
+    when(rateLimiterMock.initState()).thenReturn(rateLimit);
+    when(rateLimiterMock.isLimited(rateLimit))
+        .thenReturn(Optional.empty())
+        .thenReturn(Optional.of(refreshPeriod));
+
+    eventProcessor.handleEvent(event);
+    verify(reconciliationDispatcherMock, after(FAKE_CONTROLLER_EXECUTION_DURATION).times(1))
+        .handleExecution(any());
+    verify(retryTimerEventSourceMock, times(0))
+        .scheduleOnce((ResourceID) any(), eq(refreshPeriod.toMillis()));
+
+    eventProcessor.handleEvent(event);
+    verify(retryTimerEventSourceMock, times(1))
+        .scheduleOnce((ResourceID) any(), eq(refreshPeriod.toMillis()));
+  }
+
   @Test
   void passesResourceFromStateToDispatcher() {
     eventProcessor =