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

src/main/java/it/gov/pagopa/payhub/activities/activity/fdr/FdRIngestionActivity.java → src/main/java/it/gov/pagopa/payhub/activities/activity/paymentsreporting/FdRIngestionActivity.java

@@ -1,5 +1,5 @@
-package it.gov.pagopa.payhub.activities.activity.fdr;
-import it.gov.pagopa.payhub.activities.dto.fdr.FdRIngestionActivityResult;
+package it.gov.pagopa.payhub.activities.activity.paymentsreporting;
+import it.gov.pagopa.payhub.activities.dto.reportingflow.FdRIngestionActivityResult;
 
 /**
  * Interface for the FdRIngestionActivity.

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

@@ -0,0 +1,46 @@
+package it.gov.pagopa.payhub.activities.activity.paymentsreporting;
+
+import it.gov.pagopa.payhub.activities.activity.paymentsreporting.service.IngestionFileHandlerService;
+import it.gov.pagopa.payhub.activities.activity.paymentsreporting.service.IngestionFileValidatorService;
+import it.gov.pagopa.payhub.activities.activity.paymentsreporting.service.IngestionFlowRetrieverService;
+import it.gov.pagopa.payhub.activities.dto.reportingflow.FdRIngestionActivityResult;
+import it.gov.pagopa.payhub.activities.dto.reportingflow.IngestionFlowDTO;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.stereotype.Component;
+
+import java.util.ArrayList;
+import java.util.List;
+
+@Slf4j
+@Component
+public class FdRIngestionActivityImpl implements FdRIngestionActivity {
+	private final IngestionFlowRetrieverService ingestionFlowRetrieverService;
+	private final IngestionFileValidatorService ingestionFileValidatorService;
+	private final IngestionFileHandlerService ingestionFileHandlerService;
+
+	public FdRIngestionActivityImpl(IngestionFlowRetrieverService ingestionFlowRetrieverService,
+	                                IngestionFileValidatorService ingestionFileValidatorService,
+	                                IngestionFileHandlerService ingestionFileHandlerService) {
+		this.ingestionFlowRetrieverService = ingestionFlowRetrieverService;
+		this.ingestionFileValidatorService = ingestionFileValidatorService;
+		this.ingestionFileHandlerService = ingestionFileHandlerService;
+	}
+
+	@Override
+	public FdRIngestionActivityResult processFile(String ingestionFlowId) {
+		List<String> iufList = new ArrayList<>();
+		boolean success = true;
+
+		try {
+			IngestionFlowDTO ingestionFlowDTO = ingestionFlowRetrieverService.getIngestionFlow(Long.valueOf(ingestionFlowId));
+
+			ingestionFileValidatorService.validate(ingestionFlowDTO.getFilePathName(), ingestionFlowDTO.getFileName(), ingestionFlowDTO.getRequestTokenCode());
+
+			ingestionFileHandlerService.setUpProcess(ingestionFlowDTO.getFilePathName(), ingestionFlowDTO.getFileName());
+		} catch (Exception e) {
+			log.error("Error during IngestionActivity flowId {} due to: {}", ingestionFlowId, e.getMessage());
+			success = false;
+		}
+		return new FdRIngestionActivityResult(iufList, success);
+	}
+}

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

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

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

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

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

@@ -0,0 +1,50 @@
+package it.gov.pagopa.payhub.activities.activity.paymentsreporting.service;
+
+import it.gov.pagopa.payhub.activities.util.AESUtils;
+import it.gov.pagopa.payhub.activities.util.FileUtils;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.stereotype.Service;
+
+import java.io.IOException;
+import java.nio.file.Files;
+import java.nio.file.Path;
+import java.nio.file.Paths;
+
+@Slf4j
+@Service
+public class IngestionFileHandlerService {
+	private static final String TEMPORARY_PATH = "TEMP";
+
+	private final String dataCipherPsw;
+
+	public IngestionFileHandlerService(@Value("${data-cipher.encrypt-psw}") String dataCipherPsw) {
+		this.dataCipherPsw = dataCipherPsw;
+	}
+
+	public Path setUpProcess(String relativePath, String filename) throws IOException {
+		Path relativePathDir = Paths.get(relativePath);
+		Path encryptedFilePath = relativePathDir.resolve(filename);
+
+		Path temporaryPath = relativePathDir.resolve(TEMPORARY_PATH);
+		Files.createDirectories(temporaryPath);
+
+		String filenameNoCipher = filename.replace(AESUtils.CIPHER_EXTENSION, "");
+		Path temporaryZipFilePath = temporaryPath.resolve(filenameNoCipher);
+
+		log.debug("Decrypting file: {}", encryptedFilePath);
+		AESUtils.decrypt(dataCipherPsw, encryptedFilePath.toFile(), temporaryZipFilePath.toFile());
+
+		log.debug("Validating ZIP file: {}", temporaryZipFilePath);
+		FileUtils.isArchive(temporaryZipFilePath);
+
+		String unzippedFilename = filenameNoCipher.replace(".zip", ".xml");
+		Path outputUnzippedPath = temporaryPath.resolve(unzippedFilename);
+
+		log.debug("Unzipping file: {} to {}", temporaryZipFilePath, outputUnzippedPath);
+		FileUtils.unzip(temporaryZipFilePath, outputUnzippedPath);
+
+		log.debug("File setup process completed successfully for: {}", filename);
+		return outputUnzippedPath;
+	}
+}

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

@@ -0,0 +1,71 @@
+package it.gov.pagopa.payhub.activities.activity.paymentsreporting.service;
+
+import it.gov.pagopa.payhub.activities.exception.InvalidIngestionFileException;
+import lombok.extern.slf4j.Slf4j;
+import org.apache.commons.codec.binary.Hex;
+import org.apache.commons.io.IOUtils;
+import org.springframework.stereotype.Service;
+
+import java.io.IOException;
+import java.io.InputStream;
+import java.nio.file.Files;
+import java.nio.file.Path;
+import java.nio.file.Paths;
+import java.security.DigestInputStream;
+import java.security.MessageDigest;
+import java.security.NoSuchAlgorithmException;
+
+@Slf4j
+@Service
+public class IngestionFileValidatorService {
+
+	public void validate(String relativePath, String filename, String requestTokenCode) {
+		Path fileLocation = Paths.get(relativePath, filename);
+
+		validateFile(fileLocation);
+		validateAUTH(fileLocation.toString(), requestTokenCode);
+		validateMD5(fileLocation.toString());
+	}
+
+	private void validateFile(Path filePath) {
+		if (!Files.exists(filePath) || !Files.isRegularFile(filePath)) {
+			throw new InvalidIngestionFileException("File non trovato: " + filePath);
+		}
+	}
+
+	private void validateMD5(String filename) {
+		String md5 = filename.replace(".zip", ".md5");
+		String valueMD5 = readContentFile(md5);
+		String calculatedMD5 = calculateMd5(filename);
+		if(!valueMD5.equalsIgnoreCase(calculatedMD5)) {
+			throw new InvalidIngestionFileException("Error while calculating MD5 file value");
+		}
+	}
+
+	private void validateAUTH(String filename, String requestToken) {
+		String auth = filename.replace(".zip", ".auth");
+		String valueAUTH = readContentFile(auth);
+		if(!valueAUTH.equalsIgnoreCase(requestToken)) {
+			throw new InvalidIngestionFileException("Error while calculating MD5 file value");
+		}
+	}
+
+	private String readContentFile(String filename) {
+		try {
+			return Files.readString(Paths.get(filename));
+		} catch (IOException e) {
+			throw new InvalidIngestionFileException("Error while reading file: " + filename);
+		}
+	}
+
+	private String calculateMd5(String filename) {
+		try (InputStream is = Files.newInputStream(Paths.get(filename))) {
+			MessageDigest md = MessageDigest.getInstance("MD5");
+			DigestInputStream dis = new DigestInputStream(is, md);
+			IOUtils.toByteArray(dis);
+			return Hex.encodeHexString(md.digest());
+		} catch (NoSuchAlgorithmException | IOException e) {
+			throw new InvalidIngestionFileException("Error while calculating MD5");
+		}
+	}
+}

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

@@ -0,0 +1,27 @@
+package it.gov.pagopa.payhub.activities.activity.paymentsreporting.service;
+
+import it.gov.pagopa.payhub.activities.dao.IngestionFlowDao;
+import it.gov.pagopa.payhub.activities.dto.reportingflow.IngestionFlowDTO;
+import it.gov.pagopa.payhub.activities.exception.IngestionFlowNotFoundException;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.stereotype.Service;
+
+import java.util.Optional;
+
+@Service
+@Slf4j
+public class IngestionFlowRetrieverService {
+
+	private final IngestionFlowDao ingestionFlowDao;
+
+	public IngestionFlowRetrieverService(IngestionFlowDao ingestionFlowDao) {
+		this.ingestionFlowDao = ingestionFlowDao;
+	}
+
+	public IngestionFlowDTO getIngestionFlow(Long ingestionFlowId) {
+		Optional<IngestionFlowDTO> ingestionFlow = ingestionFlowDao.getIngestionFlow(ingestionFlowId);
+
+		return ingestionFlow
+			.orElseThrow(() -> new IngestionFlowNotFoundException("Cannot found ingestionFlow having id: "+ ingestionFlowId));
+	}
+}

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

@@ -0,0 +1,13 @@
+package it.gov.pagopa.payhub.activities.dao;
+
+import it.gov.pagopa.payhub.activities.dto.reportingflow.IngestionFlowDTO;
+
+import java.util.Optional;
+
+public interface IngestionFlowDao {
+
+	/**
+	 *  * It will return the requested IngestionFlowDTO entity from its id
+	 * */
+	Optional<IngestionFlowDTO> getIngestionFlow(Long ingestionFlowId);
+}

src/main/java/it/gov/pagopa/payhub/activities/dto/fdr/FdRIngestionActivityResult.java → src/main/java/it/gov/pagopa/payhub/activities/dto/reportingflow/FdRIngestionActivityResult.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;

src/main/java/it/gov/pagopa/payhub/activities/dto/reportingflow/IngestionFlowDTO.java

@@ -0,0 +1,37 @@
+package it.gov.pagopa.payhub.activities.dto.reportingflow;
+
+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
+@Builder
+@NoArgsConstructor
+@AllArgsConstructor
+public class IngestionFlowDTO {
+	private Long ingestionFlowId;
+	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/exception/IngestionFlowNotFoundException.java

@@ -0,0 +1,6 @@
+package it.gov.pagopa.payhub.activities.exception;
+
+public class IngestionFlowNotFoundException extends ActivitiesException {
+
+	public IngestionFlowNotFoundException(String message) { super(message); }
+}

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

@@ -0,0 +1,7 @@
+package it.gov.pagopa.payhub.activities.exception;
+
+public class InvalidIngestionFileException extends ActivitiesException {
+	public InvalidIngestionFileException(String message) {
+		super(message);
+	}
+}