add get and delete V2 endpoints

Author: Hajarel-moukh

src/main/java/fr/insee/genesis/controller/dto/rawdata/ScheduleV2Dto.java

@@ -0,0 +1,20 @@
+package fr.insee.genesis.controller.dto.rawdata;
+
+import fr.insee.genesis.domain.model.context.schedule.KraftwerkExecutionScheduleV2;
+import lombok.AllArgsConstructor;
+import lombok.Builder;
+import lombok.Data;
+import lombok.NoArgsConstructor;
+
+import java.time.LocalDateTime;
+
+@Data
+@Builder
+@NoArgsConstructor
+@AllArgsConstructor
+public class ScheduleV2Dto {
+    private String surveyName;
+    private String collectionInstrumentId;
+    private LocalDateTime lastExecution;
+    private KraftwerkExecutionScheduleV2 kraftwerkExecutionScheduleV2;
+}

src/main/java/fr/insee/genesis/controller/rest/DataProcessingContextController.java

@@ -3,6 +3,7 @@
 import fr.insee.genesis.Constants;
 import fr.insee.genesis.controller.dto.ScheduleDto;
 import fr.insee.genesis.controller.dto.ScheduleRequestDto;
+import fr.insee.genesis.controller.dto.rawdata.ScheduleV2Dto;
 import fr.insee.genesis.domain.model.context.schedule.ServiceToCall;
 import fr.insee.genesis.domain.model.context.schedule.TrustParameters;
 import fr.insee.genesis.domain.ports.api.DataProcessingContextApiPort;
@@ -252,6 +253,17 @@ public ResponseEntity<Object> getAllSchedulesV2() {
         return ResponseEntity.ok(surveyScheduleDocumentModels);
     }
 
+    @Operation(summary = "Fetch all schedules V2")
+    @GetMapping(path = "/contexts/schedules/v2")
+    @PreAuthorize("hasAnyRole('SCHEDULER','READER')")
+    public ResponseEntity<Object> getAllSchedulesV3() {
+        log.debug("Got GET all schedules V2 request");
+
+        List<ScheduleV2Dto> schedules = dataProcessingContextApiPort.getAllSchedulesV2();
+
+        log.info("Returning {} V2 schedule documents...", schedules.size());
+        return ResponseEntity.ok(schedules);
+    }
 
     @Deprecated(forRemoval = true)
     @Operation(summary = "Set last execution date of a partition with new date or nothing")
@@ -317,6 +329,21 @@ public ResponseEntity<Object> deleteSchedulesByCollectionInstrumentId(
         return ResponseEntity.ok().build();
     }
 
+    @Operation(summary = "Delete V2 Kraftwerk execution schedule of a collection instrument id")
+    @DeleteMapping(path = "/contexts/{collectionInstrumentId}/schedules/v2")
+    @PreAuthorize("hasRole('USER_KRAFTWERK')")
+    public ResponseEntity<Object> deleteSchedulesV2ByCollectionInstrumentId(
+            @PathVariable("collectionInstrumentId") String collectionInstrumentId
+    ){
+        try {
+            dataProcessingContextApiPort.deleteSchedulesV2ByCollectionInstrumentId(collectionInstrumentId);
+        } catch (GenesisException e) {
+            return new ResponseEntity<>(e.getMessage(), HttpStatusCode.valueOf(e.getStatus()));
+        }
+        log.info("V2 schedule deleted for collection instrument {}", collectionInstrumentId);
+        return ResponseEntity.ok().build();
+    }
+
     @Operation(summary = "Delete expired schedules")
     @DeleteMapping(path = "/context/schedules/expired-schedules")
     @PreAuthorize("hasRole('SCHEDULER')")

src/main/java/fr/insee/genesis/domain/model/context/DataProcessingContextModel.java

@@ -1,6 +1,7 @@
 package fr.insee.genesis.domain.model.context;
 
 import fr.insee.genesis.controller.dto.ScheduleDto;
+import fr.insee.genesis.controller.dto.rawdata.ScheduleV2Dto;
 import fr.insee.genesis.domain.model.context.schedule.KraftwerkExecutionSchedule;
 import fr.insee.genesis.domain.model.context.schedule.KraftwerkExecutionScheduleV2;
 import lombok.AllArgsConstructor;
@@ -42,4 +43,13 @@ public ScheduleDto toScheduleDto(){
                 .kraftwerkExecutionScheduleList(kraftwerkExecutionScheduleList)
                 .build();
     }
+
+    public ScheduleV2Dto toScheduleV2Dto() {
+        return ScheduleV2Dto.builder()
+                .surveyName(partitionId)
+                .collectionInstrumentId(collectionInstrumentId)
+                .lastExecution(lastExecution)
+                .kraftwerkExecutionScheduleV2(kraftwerkExecutionScheduleV2)
+                .build();
+    }
 }

src/main/java/fr/insee/genesis/domain/ports/api/DataProcessingContextApiPort.java

@@ -1,6 +1,7 @@
 package fr.insee.genesis.domain.ports.api;
 
 import fr.insee.genesis.controller.dto.ScheduleDto;
+import fr.insee.genesis.controller.dto.rawdata.ScheduleV2Dto;
 import fr.insee.genesis.controller.utils.ExportType;
 import fr.insee.genesis.domain.model.context.DataProcessingContextModel;
 import fr.insee.genesis.domain.model.context.schedule.ServiceToCall;
@@ -44,10 +45,15 @@ void saveKraftwerkExecutionScheduleV2(String collectionInstrumentId,
     void updateLastExecutionDateByCollectionInstrumentId(String collectionInstrumentId, LocalDateTime newDate) throws GenesisException;
 
     void deleteSchedules(String surveyName) throws GenesisException;
+
+    void deleteSchedulesV2ByCollectionInstrumentId(String collectionInstrumentId) throws GenesisException;
+
     void deleteSchedulesByCollectionInstrumentId(String collectionInstrumentId) throws GenesisException;
 
     List<ScheduleDto> getAllSchedules();
 
+    List<ScheduleV2Dto> getAllSchedulesV2();
+
     void deleteExpiredSchedules(String logFolder) throws GenesisException;
 
     long countSchedules();

src/main/java/fr/insee/genesis/domain/service/context/DataProcessingContextService.java

@@ -4,6 +4,7 @@
 import com.fasterxml.jackson.datatype.jsr310.JavaTimeModule;
 import fr.insee.genesis.Constants;
 import fr.insee.genesis.controller.dto.ScheduleDto;
+import fr.insee.genesis.controller.dto.rawdata.ScheduleV2Dto;
 import fr.insee.genesis.controller.utils.ExportType;
 import fr.insee.genesis.domain.model.context.DataProcessingContextModel;
 import fr.insee.genesis.domain.model.context.schedule.KraftwerkExecutionSchedule;
@@ -207,6 +208,17 @@ public void deleteSchedules(String partitionId) throws GenesisException {
         dataProcessingContextPersistancePort.save(DataProcessingContextMapper.INSTANCE.modelToDocument(dataProcessingContextModel));
     }
 
+    @Override
+    public void deleteSchedulesV2ByCollectionInstrumentId(String collectionInstrumentId) throws GenesisException {
+                DataProcessingContextModel dataProcessingContextModel =
+                dataProcessingContextPersistancePort.findByCollectionInstrumentId(collectionInstrumentId);
+        if (dataProcessingContextModel == null) {
+            throw new GenesisException(404, NOT_FOUND_MESSAGE);
+        }
+        dataProcessingContextModel.setKraftwerkExecutionScheduleV2(null);
+        dataProcessingContextPersistancePort.save(DataProcessingContextMapper.INSTANCE.modelToDocument(dataProcessingContextModel));
+    }
+
     @Override
     public void deleteSchedulesByCollectionInstrumentId(String collectionInstrumentId) throws GenesisException {
         DataProcessingContextModel dataProcessingContextModel =
@@ -232,6 +244,22 @@ public List<ScheduleDto> getAllSchedules() {
         return scheduleDtos;
     }
 
+    @Override
+    public List<ScheduleV2Dto> getAllSchedulesV2() {
+        List<ScheduleV2Dto> scheduleV2Dtos = new ArrayList<>();
+
+        List<DataProcessingContextModel> dataProcessingContextModels =
+                DataProcessingContextMapper.INSTANCE.listDocumentToListModel(
+                        dataProcessingContextPersistancePort.findAll()
+                );
+
+        dataProcessingContextModels.forEach(
+                model -> scheduleV2Dtos.add(model.toScheduleV2Dto())
+        );
+
+        return scheduleV2Dtos;
+    }
+
     @Override
     public void deleteExpiredSchedules(String logFolder) throws GenesisException {
         List<DataProcessingContextModel> dataProcessingContextModels =