add tests

Author: Hajarel-moukh

src/test/java/fr/insee/genesis/domain/service/rawdata/LunaticJsonRawDataServiceTest.java

@@ -15,6 +15,7 @@
 import fr.insee.genesis.domain.service.surveyunit.SurveyUnitQualityService;
 import fr.insee.genesis.domain.service.surveyunit.SurveyUnitService;
 import fr.insee.genesis.domain.utils.JsonUtils;
+import fr.insee.genesis.exceptions.GenesisException;
 import fr.insee.genesis.infrastructure.mappers.DataProcessingContextMapper;
 import fr.insee.genesis.infrastructure.mappers.LunaticJsonRawDataDocumentMapper;
 import fr.insee.genesis.infrastructure.utils.FileUtils;
@@ -692,4 +693,46 @@ void getValueString_double_test(){
 
         Assertions.assertThat(getValueString(doubleObject)).isEqualTo("101010101010.111");
     }
+
+    @Test
+    void reprocessRawData_should_return_empty_result_when_no_processed_interrogation_ids_found() throws Exception {
+        // GIVEN
+        lunaticJsonRawDataPersistanceStub.getMongoStub().clear();
+        surveyUnitPersistencePortStub.getMongoStub().clear();
+
+        String questionnaireId = "TESTIDQUEST";
+
+        // WHEN
+        DataProcessResult result = lunaticJsonRawDataService.reprocessRawData(questionnaireId, null, null);
+
+        // THEN
+        Assertions.assertThat(result).isNotNull();
+        Assertions.assertThat(result.dataCount()).isEqualTo(0);
+        Assertions.assertThat(result.formattedDataCount()).isEqualTo(0);
+        Assertions.assertThat(result.errors()).isEmpty();
+    }
+
+    @Test
+    void reprocessRawData_should_throw_when_endDate_is_provided_without_sinceDate() {
+        String questionnaireId = "TESTIDQUEST";
+        LocalDateTime endDate = LocalDateTime.now();
+
+        Assertions.assertThatThrownBy(() ->
+                        lunaticJsonRawDataService.reprocessRawData(questionnaireId, null, endDate))
+                .isInstanceOf(GenesisException.class)
+                .hasMessage("endDate cannot be provided without sinceDate");
+    }
+
+    @Test
+    void reprocessRawData_should_throw_when_endDate_is_before_sinceDate() {
+        String questionnaireId = "TESTIDQUEST";
+        LocalDateTime sinceDate = LocalDateTime.of(2024, 1, 10, 10, 0);
+        LocalDateTime endDate = LocalDateTime.of(2024, 1, 9, 10, 0);
+
+        Assertions.assertThatThrownBy(() ->
+                        lunaticJsonRawDataService.reprocessRawData(questionnaireId, sinceDate, endDate))
+                .isInstanceOf(GenesisException.class)
+                .hasMessage("endDate must be after or equal to sinceDate");
+    }
+
 }

src/test/java/fr/insee/genesis/stubs/LunaticJsonMongoDBRepositoryStub.java

@@ -197,13 +197,30 @@ public boolean existsByInterrogationId(String interrogationId) {
     }
 
     @Override
-    public List<String> findProcessedInterrogationIdsByQuestionnaireIdAndRecordDateBetween(String questionnaireId, LocalDateTime sinceDate, LocalDateTime endDate) {
-        return List.of();
+    public List<String> findProcessedInterrogationIdsByQuestionnaireId(String questionnaireId) {
+        return documents.stream()
+                .filter(doc -> Objects.equals(doc.questionnaireId(), questionnaireId))
+                .filter(doc -> doc.processDate() != null)
+                .map(LunaticJsonRawDataDocument::interrogationId)
+                .distinct()
+                .toList();
     }
 
     @Override
-    public List<String> findProcessedInterrogationIdsByQuestionnaireId(String questionnaireId) {
-        return List.of();
+    public List<String> findProcessedInterrogationIdsByQuestionnaireIdAndRecordDateBetween(
+            String questionnaireId,
+            LocalDateTime sinceDate,
+            LocalDateTime endDate
+    ) {
+        return documents.stream()
+                .filter(doc -> Objects.equals(doc.questionnaireId(), questionnaireId))
+                .filter(doc -> doc.processDate() != null)
+                .filter(doc -> doc.recordDate() != null)
+                .filter(doc -> !doc.recordDate().isBefore(sinceDate))
+                .filter(doc -> !doc.recordDate().isAfter(endDate))
+                .map(LunaticJsonRawDataDocument::interrogationId)
+                .distinct()
+                .toList();
     }
 
     // Implémentations vides requises par MongoRepository

src/test/java/fr/insee/genesis/stubs/LunaticJsonRawDataPersistanceStub.java

@@ -130,7 +130,27 @@ public void updateProcessDates(String campaignId, Set<String> interrogationIds)
 
     @Override
     public void resetProcessDates(String questionnaireId, Set<String> interrogationIds) {
-        return;
+        for (int i = 0; i < mongoStub.size(); i++) {
+            LunaticJsonRawDataDocument document = mongoStub.get(i);
+
+            if (document.questionnaireId().equals(questionnaireId)
+                    && interrogationIds.contains(document.interrogationId())) {
+
+                LunaticJsonRawDataDocument newDocument = LunaticJsonRawDataDocument.builder()
+                        .id(document.id())
+                        .campaignId(document.campaignId())
+                        .questionnaireId(document.questionnaireId())
+                        .interrogationId(document.interrogationId())
+                        .idUE(document.idUE())
+                        .mode(document.mode())
+                        .data(document.data())
+                        .recordDate(document.recordDate())
+                        .processDate(null)
+                        .build();
+
+                mongoStub.set(i, newDocument);
+            }
+        }
     }
 
     @Override