From 858096e72b985d262e02148492ff26d74f3c6018 Mon Sep 17 00:00:00 2001
From: AngeloCaporaso <angelo.caporaso@pagopa.it>
Date: Tue, 17 Sep 2024 16:54:51 +0200
Subject: [PATCH] [PAGOPA-2113] test(Recovery): Add
 testRecoverReceiptKOAll_notEmpty

---
 .../service/RecoveryServiceTest.java          | 28 ++++++++++++++++++-
 1 file changed, 27 insertions(+), 1 deletion(-)

diff --git a/src/test/java/it/gov/pagopa/wispconverter/service/RecoveryServiceTest.java b/src/test/java/it/gov/pagopa/wispconverter/service/RecoveryServiceTest.java
index de39d4a1..4c1d309e 100644
--- a/src/test/java/it/gov/pagopa/wispconverter/service/RecoveryServiceTest.java
+++ b/src/test/java/it/gov/pagopa/wispconverter/service/RecoveryServiceTest.java
@@ -14,6 +14,7 @@
 import org.junit.jupiter.api.Test;
 import org.mockito.*;
 
+import java.time.Instant;
 import java.time.LocalDate;
 import java.time.ZoneOffset;
 import java.time.ZonedDateTime;
@@ -77,7 +78,6 @@ public void testRecoverReceiptKO() throws Exception {
         verify(cacheRepository, times(2)).insert(anyString(), anyString(), anyLong(), any(ChronoUnit.class), anyBoolean());
     }
 
-
     @Test
     public void testRecoverReceiptKOAll() {
         // Arrange
@@ -94,6 +94,32 @@ public void testRecoverReceiptKOAll() {
         assertEquals(0, recoveredReceipt);
     }
 
+    @Test
+    public void testRecoverReceiptKOAll_notEmpty() {
+        // Arrange
+        ZonedDateTime dateFrom = ZonedDateTime.now(ZoneOffset.UTC).minusHours(5);
+        ZonedDateTime dateTo = ZonedDateTime.now(ZoneOffset.UTC).minusHours(4);
+        List<RTEntity> mockRTEntities = List.of(RTEntity.builder()
+                                                        .iuv("iuv")
+                                                        .ccp("ccp")
+                                                        .idDominio("idDominio")
+                                                        .build());
+        List<ReEventEntity> mockReEventEntities = List.of(ReEventEntity.builder()
+                                                                  .status("GENERATED_CACHE_ABOUT_RPT_FOR_RT_GENERATION")
+                                                                  .ccp("ccp2")
+                                                                  .insertedTimestamp(Instant.now())
+                                                                  .build());
+
+        when(rtRepository.findPendingRT(anyString(), anyString())).thenReturn(mockRTEntities);
+        when(reRepository.findByIuvAndOrganizationId(anyString(), anyString(), anyString(), anyString())).thenReturn(mockReEventEntities);
+
+        // Act
+        int recoveredReceipt = recoveryService.recoverReceiptKOAll(dateFrom, dateTo);
+
+        // Assert
+        assertEquals(1, recoveredReceipt);
+    }
+
     @Test
     public void testRecoverMissingRedirect() {
         // Arrange