feat: P4ADEV-1545 fdr ingestion actity implementation retrieval via query file validation

src/main/java/it/gov/pagopa/payhub/activities/activity/fdr/UpdateIngestionFlowStatusActivity.java → src/main/java/it/gov/pagopa/payhub/activities/activity/ingestionflow/UpdateIngestionFlowStatusActivity.java

@@ -1,4 +1,4 @@
-package it.gov.pagopa.payhub.activities.activity.fdr;
+package it.gov.pagopa.payhub.activities.activity.ingestionflow;
 
 /**
  * Interface for the UpdateIngestionFlowStatusActivity.

src/main/java/it/gov/pagopa/payhub/activities/activity/paymentsreporting/PaymentsReportingIngestionFlowFileActivity.java

@@ -0,0 +1,17 @@
+package it.gov.pagopa.payhub.activities.activity.paymentsreporting;
+import it.gov.pagopa.payhub.activities.dto.reportingflow.PaymentsReportingIngestionFlowFileActivityResult;
+
+/**
+ * Interface for the PaymentsReportingIngestionFlowFileActivity.
+ * Defines methods for processing payments reporting files based on an IngestionFlowFile ID.
+ */
+public interface PaymentsReportingIngestionFlowFileActivity {
+
+    /**
+     * Processes a payments reporting file based on the provided IngestionFlowFile ID.
+     *
+     * @param ingestionFlowFileId the unique identifier related to the file to process.
+     * @return {@link PaymentsReportingIngestionFlowFileActivityResult} containing the list of IUFs and status.
+     */
+    PaymentsReportingIngestionFlowFileActivityResult processFile(Long ingestionFlowFileId);
+}

src/main/java/it/gov/pagopa/payhub/activities/activity/paymentsreporting/PaymentsReportingIngestionFlowFileActivityImpl.java

@@ -0,0 +1,48 @@
+package it.gov.pagopa.payhub.activities.activity.paymentsreporting;
+
+import it.gov.pagopa.payhub.activities.dao.IngestionFlowFileDao;
+import it.gov.pagopa.payhub.activities.dto.paymentsreporting.IngestionFlowFileDTO;
+import it.gov.pagopa.payhub.activities.dto.reportingflow.PaymentsReportingIngestionFlowFileActivityResult;
+import it.gov.pagopa.payhub.activities.exception.IngestionFlowNotFoundException;
+import it.gov.pagopa.payhub.activities.service.ingestionflow.IngestionFlowFileRetrieverService;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.context.annotation.Lazy;
+import org.springframework.stereotype.Component;
+
+import java.nio.file.Path;
+import java.util.ArrayList;
+import java.util.List;
+
+@Slf4j
+@Lazy
+@Component
+public class PaymentsReportingIngestionFlowFileActivityImpl implements PaymentsReportingIngestionFlowFileActivity {
+	private final IngestionFlowFileDao ingestionFlowFileDao;
+	private final IngestionFlowFileRetrieverService ingestionFlowFileRetrieverService;
+
+
+	public PaymentsReportingIngestionFlowFileActivityImpl(IngestionFlowFileDao ingestionFlowFileDao,
+	                                                      IngestionFlowFileRetrieverService ingestionFlowFileRetrieverService) {
+		this.ingestionFlowFileDao = ingestionFlowFileDao;
+		this.ingestionFlowFileRetrieverService = ingestionFlowFileRetrieverService;
+	}
+
+
+	@Override
+	public PaymentsReportingIngestionFlowFileActivityResult processFile(Long ingestionFlowFileId) {
+		List<String> iufList = new ArrayList<>();
+		boolean success = true;
+
+		try {
+			IngestionFlowFileDTO ingestionFlowFileDTO = ingestionFlowFileDao.findById(ingestionFlowFileId)
+				.orElseThrow(() -> new IngestionFlowNotFoundException("Cannot found ingestionFlow having id: "+ ingestionFlowFileId));
+
+			ingestionFlowFileRetrieverService.retrieveAndUnzipFile(Path.of(ingestionFlowFileDTO.getFilePathName()), ingestionFlowFileDTO.getFileName());
+
+		} catch (Exception e) {
+			log.error("Error during PaymentsReportingIngestionFlowFileActivity ingestionFlowFileId {} due to: {}", ingestionFlowFileId, e.getMessage());
+			success = false;
+		}
+		return new PaymentsReportingIngestionFlowFileActivityResult(iufList, success);
+	}
+}

src/main/java/it/gov/pagopa/payhub/activities/activity/fdr/SendEmailIngestionFlowActivity.java → src/main/java/it/gov/pagopa/payhub/activities/activity/utility/SendEmailIngestionFlowActivity.java

@@ -1,4 +1,4 @@
-package it.gov.pagopa.payhub.activities.activity.fdr;
+package it.gov.pagopa.payhub.activities.activity.utility;
 
 /**
  * Interface for SendEmailIngestionFlowActivity.

src/main/java/it/gov/pagopa/payhub/activities/dao/IngestionFlowFileDao.java

@@ -0,0 +1,29 @@
+package it.gov.pagopa.payhub.activities.dao;
+
+import it.gov.pagopa.payhub.activities.dto.paymentsreporting.IngestionFlowFileDTO;
+
+import java.util.Optional;
+
+/**
+ * Data Access Object (DAO) interface for managing ingestion flows.
+ *
+ * <p>
+ * The {@code IngestionFlowFileDao} provides an abstraction for accessing and manipulating
+ * ingestion flow data. It focuses on retrieving ingestion flow details from the underlying
+ * data source using defined operations.
+ * </p>
+ *
+ * @see IngestionFlowFileDTO
+ */
+public interface IngestionFlowFileDao {
+
+	/**
+	 * Retrieves the {@link IngestionFlowFileDTO} entity based on the provided ingestion flow ID.
+	 *
+	 * @param ingestionFlowFileId the unique identifier of the ingestion flow to be retrieved.
+	 * @return an {@link Optional} containing the requested {@link IngestionFlowFileDTO} if found,
+	 *         or an empty {@link Optional} if no matching entity exists.
+	 */
+	Optional<IngestionFlowFileDTO> findById(Long ingestionFlowFileId);
+}
+

src/main/java/it/gov/pagopa/payhub/activities/dto/paymentsreporting/IngestionFlowFileDTO.java

@@ -0,0 +1,42 @@
+package it.gov.pagopa.payhub.activities.dto.paymentsreporting;
+
+import it.gov.pagopa.payhub.activities.dto.OrganizationDTO;
+import lombok.AllArgsConstructor;
+import lombok.Builder;
+import lombok.Data;
+import lombok.NoArgsConstructor;
+
+import java.sql.Timestamp;
+
+/**
+ * Data Transfer Object (DTO) representing the details of an ingestion flow.
+ *
+ **/
+@Data
+@Builder
+@NoArgsConstructor
+@AllArgsConstructor
+public class IngestionFlowFileDTO {
+	private Long ingestionFlowFileId;
+	private int version;
+	private OrganizationDTO orgId;
+	private String PspIdentifier;
+	private String flowIdentifierCode;
+	private Timestamp flowDateTime;
+	private String flowType;
+	private String flowTypeCode;
+	private String operatorName;
+	private String status;
+	private String filePathName;
+	private String fileName;
+	private Long downloadedFileSize;
+	private String requestTokenCode;
+	private Timestamp creationDate;
+	private Timestamp lastChangeDate;
+	private String fileSourceCode;
+	private String descriptionFileNameScraps;
+	private String errorCode;
+	private Long TotalRowsNumber;
+	private Long numberLinesImportedCorrectly;
+}
+

src/main/java/it/gov/pagopa/payhub/activities/dto/fdr/FdRIngestionActivityResult.java → src/main/java/it/gov/pagopa/payhub/activities/dto/reportingflow/PaymentsReportingIngestionFlowFileActivityResult.java

@@ -1,4 +1,4 @@
-package it.gov.pagopa.payhub.activities.dto.fdr;
+package it.gov.pagopa.payhub.activities.dto.reportingflow;
 
 import lombok.AllArgsConstructor;
 import lombok.Data;
@@ -7,12 +7,12 @@
 import java.util.List;
 
 /**
- * DTO for the FdRIngestionResponse, representing the result of file processing.
+ * DTO for the PaymentsReportingIngestionFlowFileActivityResult, representing the result of file processing.
  */
 @Data
 @NoArgsConstructor
 @AllArgsConstructor
-public class FdRIngestionActivityResult {
+public class PaymentsReportingIngestionFlowFileActivityResult {
     /** List of extracted IUFs */
     private List<String> iufs;
     /** Success flag for the operation */

src/main/java/it/gov/pagopa/payhub/activities/exception/ActivitiesException.java

@@ -1,7 +1,16 @@
 package it.gov.pagopa.payhub.activities.exception;
 
+/**
+ * A custom exception that represents errors related to activities and extends {@link RuntimeException}.
+ *
+ */
 public class ActivitiesException extends RuntimeException {
 
+    /**
+     * Constructs a new {@code ActivitiesException} with the specified detail message.
+     *
+     * @param message the detail message explaining the cause of the exception.
+     */
     public ActivitiesException(String message) {
         super(message);
     }

src/main/java/it/gov/pagopa/payhub/activities/exception/IngestionFlowNotFoundException.java

@@ -0,0 +1,19 @@
+package it.gov.pagopa.payhub.activities.exception;
+
+/**
+ * A custom exception that indicates the absence of an expected ingestion flow
+ * in the application's processing logic.
+ *
+ */
+public class IngestionFlowNotFoundException extends ActivitiesException {
+
+	/**
+	 * Constructs a new {@code IngestionFlowNotFoundException} with the specified detail message.
+	 *
+	 * @param message the detail message explaining the cause of the exception.
+	 */
+	public IngestionFlowNotFoundException(String message) {
+		super(message);
+	}
+}
+

src/main/java/it/gov/pagopa/payhub/activities/exception/InvalidIngestionFileException.java

@@ -0,0 +1,19 @@
+package it.gov.pagopa.payhub.activities.exception;
+
+/**
+ * A custom exception that indicates an invalid ingestion file encountered
+ * during the application's processing operations.
+ *
+ */
+public class InvalidIngestionFileException extends ActivitiesException {
+
+	/**
+	 * Constructs a new {@code InvalidIngestionFileException} with the specified detail message.
+	 *
+	 * @param message the detail message explaining the cause of the exception.
+	 */
+	public InvalidIngestionFileException(String message) {
+		super(message);
+	}
+}
+

src/main/java/it/gov/pagopa/payhub/activities/service/FileValidatorService.java

@@ -0,0 +1,48 @@
+package it.gov.pagopa.payhub.activities.service;
+
+import it.gov.pagopa.payhub.activities.exception.InvalidIngestionFileException;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.context.annotation.Lazy;
+import org.springframework.stereotype.Service;
+
+import java.io.IOException;
+import java.io.RandomAccessFile;
+import java.nio.file.Files;
+import java.nio.file.Path;
+
+/**
+ * Service class responsible for validation files.
+ */
+@Lazy
+@Slf4j
+@Service
+public class FileValidatorService {
+
+	/**
+	 * Validates that the file exists and is a regular file.
+	 *
+	 * @param filePath the path to the file.
+	 * @throws InvalidIngestionFileException if the file does not exist or is not a regular file.
+	 */
+	public void validateFile(Path filePath) {
+		if (!Files.exists(filePath) || !Files.isRegularFile(filePath)) {
+			throw new InvalidIngestionFileException("File not found: " + filePath);
+		}
+	}
+
+	/**
+	 * Checks if the specified file is a valid archive by analyzing its signature.
+	 *
+	 * @param zipFilePath the path to the ZIP file to check.
+	 * @return true if the file is a valid ZIP archive; false otherwise.
+	 * @throws InvalidIngestionFileException if the file is not a valid archive.
+	 */
+	public boolean isArchive(Path zipFilePath) {
+		try (RandomAccessFile raf = new RandomAccessFile(zipFilePath.toFile(), "r")) {
+			int fileSignature = raf.readInt();
+			return fileSignature == 0x504B0304 || fileSignature == 0x504B0506 || fileSignature == 0x504B0708;
+		} catch (IOException e) {
+			throw new InvalidIngestionFileException("Invalid zip file");
+		}
+	}
+}