wip

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

Author: csviri

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

@@ -504,6 +504,8 @@ public void run() {
               return;
             }
             executionScope.setDeleteEvent(true);
+            executionScope.setDeleteFinalStateUnknown(
+                state.orElseThrow().isDeleteFinalStateUnknown());
           } else {
             log.debug("Skipping execution; primary resource missing from cache: {}", resourceID);
             return;

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

@@ -262,7 +262,6 @@ private PostExecutionControl<P> createPostExecutionControl(
     return postExecutionControl;
   }
 
-  // todo test
   private void updatePostExecutionControlWithReschedule(
       PostExecutionControl<P> postExecutionControl,
       BaseControl<?> baseControl,

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

@@ -491,6 +491,28 @@ void cleansUpForDeleteEventEvenIfProcessorNotStarted() {
     // no exception thrown
   }
 
+  @Test
+  void allEventModeProcessesDeleteEvent() {}
+
+  @Test
+  void allEventModeRetriesDeleteEventError() {}
+
+  @Test
+  void processesAdditionalEventWhileInDeleteModeRetry() {}
+
+  @Test
+  void allEventModeIfNoRetryInCleanupOnError() {
+  }
+
+  @Test
+  void onAllEventModeIfRetryExhaustedCleansUpState() {
+  }
+
+  @Test
+  void passesResourceFromStateToDispatcher() {
+    // check also last state unknown
+  }
+
   private ResourceID eventAlreadyUnderProcessing() {
     when(reconciliationDispatcherMock.handleExecution(any()))
         .then(

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

@@ -703,6 +703,15 @@ void reconcilerContextUsesTheSameInstanceOfResourceAsParam() {
         .isNotSameAs(testCustomResource);
   }
 
+  @Test
+  void allEventModeNoReSchedulesAllowedForDeleteEvent() {}
+
+  @Test
+  void allEventModeCallsCleanupOnDeleteEvent() {}
+
+  @Test
+  void allEventModeCallsCleanupOnMarkedForDeletion() {}
+
   private ObservedGenCustomResource createObservedGenCustomResource() {
     ObservedGenCustomResource observedGenCustomResource = new ObservedGenCustomResource();
     observedGenCustomResource.setMetadata(new ObjectMeta());