fixed cleanup endlessly retrying to delete

pom.xml

@@ -10,7 +10,7 @@
     </parent>
     <groupId>ch.admin.bag.covidcertificate</groupId>
     <artifactId>cc-management-service</artifactId>
-    <version>4.12.2</version>
+    <version>4.12.3</version>
     <name>cc-management-service</name>
     <description>Service for generating Covid Certificates</description>
 

src/main/java/ch/admin/bag/covidcertificate/service/CleanupScheduler.java

@@ -75,6 +75,8 @@ public void processCleanup() {
                         log.error("CLEANUP | {} - cleaning failed, retry #{}/{}; throwed '{}'", effort.getName(), ++retry, MAX_RETRIES, e);
                         if (retry < MAX_RETRIES) {
                             deleted = -1;
+                        } else {
+                            break;
                         }
                     }
                 }

src/test/java/ch/admin/bag/covidcertificate/service/CleanupSchedulerTest.java

@@ -7,7 +7,10 @@
 import org.mockito.InjectMocks;
 import org.mockito.Mock;
 import org.mockito.junit.jupiter.MockitoExtension;
+import org.postgresql.util.PSQLException;
+import org.postgresql.util.PSQLState;
 
+import java.io.EOFException;
 import java.time.LocalDate;
 import java.util.Collections;
 import java.util.Map;
@@ -59,12 +62,34 @@ void processCleanup_oneSpotConfigured() {
 
         when(cleanupService.create(eq("name2"), any(Cleanup.class))).thenReturn(effort2);
         when(cleanupService.getCount(eq(effort2), any(LocalDate.class))).thenReturn(5L);
-        when(cleanupService.delete(eq(effort2), any(LocalDate.class), eq(false))).thenReturn(0L);
         when(cleanupService.delete(eq(effort2), any(LocalDate.class), eq(true))).thenReturn(0L);
+        when(cleanupService.delete(eq(effort2), any(LocalDate.class), eq(false))).thenReturn(0L);
         doNothing().when(cleanupService).destroy(eq(effort2));
 
         cleanupScheduler.processCleanup();
 
         verify(cleanupConfig).getSpots();
     }
+
+    @Test
+    void processCleanup_deleteThrowsException() {
+        Map<String, Cleanup> map = new TreeMap<>();
+        map.put("name1", new Cleanup());
+        map.put("name2", new Cleanup());
+        when(cleanupConfig.getSpots()).thenReturn(map);
+
+        CleanupService.CleaningEffort effort1 = new CleanupService.CleaningEffort("name1",
+                "countQuery", "deleteUntilQuery", "deleteUntilBatchQuery", 5,
+                null, null);
+
+        when(cleanupService.create(eq("name1"), any(Cleanup.class))).thenReturn(effort1);
+        when(cleanupService.getCount(eq(effort1), any(LocalDate.class))).thenReturn(5L);
+        when(cleanupService.delete(eq(effort1), any(LocalDate.class), eq(true)))
+                .thenAnswer(invocation -> { throw new EOFException(null); });
+        doNothing().when(cleanupService).destroy(eq(effort1));
+
+        cleanupScheduler.processCleanup();
+
+        verify(cleanupConfig).getSpots();
+    }
 }