feat: P4ADEV-1421-fdr-create-temporal-activity

build.gradle.kts

@@ -71,6 +71,8 @@ dependencies {
 
 	implementation("com.fasterxml.jackson.module:jackson-module-parameter-names:$jacksonModuleVersion")
 
+    // Temporal.io
+	implementation ("io.temporal:temporal-sdk:1.19.0")
 	//	Testing
 	testImplementation("org.springframework.boot:spring-boot-starter-test")
 	testImplementation("org.junit.jupiter:junit-jupiter-api")

gradle.lockfile

@@ -10,17 +10,42 @@ com.fasterxml.jackson.datatype:jackson-datatype-jsr310:2.17.2=compileClasspath
 com.fasterxml.jackson.module:jackson-module-parameter-names:2.18.1=compileClasspath
 com.fasterxml.jackson:jackson-bom:2.18.1=compileClasspath
 com.fasterxml:classmate:1.7.0=compileClasspath
+com.google.api.grpc:proto-google-common-protos:2.9.0=compileClasspath
+com.google.code.findbugs:jsr305:3.0.2=compileClasspath
+com.google.code.gson:gson:2.10.1=compileClasspath
+com.google.errorprone:error_prone_annotations:2.14.0=compileClasspath
+com.google.guava:failureaccess:1.0.1=compileClasspath
+com.google.guava:guava:31.1-jre=compileClasspath
+com.google.guava:listenablefuture:9999.0-empty-to-avoid-conflict-with-guava=compileClasspath
+com.google.j2objc:j2objc-annotations:1.3=compileClasspath
+com.google.protobuf:protobuf-java-util:3.22.0=compileClasspath
+com.google.protobuf:protobuf-java:3.21.7=compileClasspath
+com.uber.m3:tally-core:0.13.0=compileClasspath
 commons-codec:commons-codec:1.16.1=compileClasspath
 commons-io:commons-io:2.16.1=compileClasspath
+io.grpc:grpc-api:1.53.0=compileClasspath
+io.grpc:grpc-bom:1.53.0=compileClasspath
+io.grpc:grpc-context:1.53.0=compileClasspath
+io.grpc:grpc-core:1.53.0=compileClasspath
+io.grpc:grpc-netty-shaded:1.53.0=compileClasspath
+io.grpc:grpc-protobuf-lite:1.53.0=compileClasspath
+io.grpc:grpc-protobuf:1.53.0=compileClasspath
+io.grpc:grpc-services:1.53.0=compileClasspath
+io.grpc:grpc-stub:1.53.0=compileClasspath
+io.micrometer:micrometer-bom:1.9.9=compileClasspath
 io.micrometer:micrometer-commons:1.13.6=compileClasspath
+io.micrometer:micrometer-core:1.13.6=compileClasspath
 io.micrometer:micrometer-observation:1.13.6=compileClasspath
+io.temporal:temporal-sdk:1.19.0=compileClasspath
+io.temporal:temporal-serviceclient:1.19.0=compileClasspath
 jakarta.annotation:jakarta.annotation-api:2.1.1=compileClasspath
 jakarta.validation:jakarta.validation-api:3.0.2=compileClasspath
 org.apache.commons:commons-compress:1.27.1=compileClasspath
 org.apache.commons:commons-lang3:3.17.0=compileClasspath
 org.apache.commons:commons-text:1.12.0=compileClasspath
 org.apache.logging.log4j:log4j-api:2.23.1=compileClasspath
 org.apache.logging.log4j:log4j-to-slf4j:2.23.1=compileClasspath
+org.checkerframework:checker-qual:3.12.0=compileClasspath
 org.codehaus.janino:commons-compiler:3.1.12=compileClasspath
 org.codehaus.janino:janino:3.1.12=compileClasspath
 org.hibernate.validator:hibernate-validator:8.0.1.Final=compileClasspath

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

@@ -0,0 +1,23 @@
+package it.gov.pagopa.payhub.activities.activity.fdr;
+
+import io.temporal.activity.ActivityInterface;
+import io.temporal.activity.ActivityMethod;
+import it.gov.pagopa.payhub.activities.dto.fdr.FdRIngestionResponse;
+import it.gov.pagopa.payhub.activities.dto.fdr.FdRIngestionResponse;
+
+/**
+ * Interface for the FdRIngestionActivity.
+ * Defines methods for processing files based on an ID.
+ */
+@ActivityInterface
+public interface FdRIngestionActivity {
+
+    /**
+     * Processes a file based on the provided ID.
+     *
+     * @param fileId the unique identifier of the file to process.
+     * @return {@link FdRIngestionResponse} containing the list of IUFs and status.
+     */
+    @ActivityMethod
+    FdRIngestionResponse processFile(String fileId);
+}

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

@@ -0,0 +1,22 @@
+package it.gov.pagopa.payhub.activities.activity.fdr;
+
+import io.temporal.activity.ActivityInterface;
+import io.temporal.activity.ActivityMethod;
+
+/**
+ * Interface for SendEmailIngestionFlowActivity.
+ * Sends an email based on the status of a processed file identified by its ID.
+ */
+@ActivityInterface
+public interface SendEmailIngestionFlowActivity {
+
+    /**
+     * Sends an email based on the process result of the given file ID.
+     *
+     * @param fileId       the unique identifier of the imported file.
+     * @param success      true if the process succeeded, false otherwise.
+     * @return true if the email was sent successfully, false otherwise.
+     */
+    @ActivityMethod
+    boolean sendEmail(String fileId, boolean success);
+}

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

@@ -0,0 +1,22 @@
+package it.gov.pagopa.payhub.activities.activity.fdr;
+
+import io.temporal.activity.ActivityInterface;
+import io.temporal.activity.ActivityMethod;
+
+/**
+ * Interface for the UpdateIngestionFlowStatusActivity.
+ * Updates the status of a database row identified by the provided ID.
+ */
+@ActivityInterface
+public interface UpdateIngestionFlowStatusActivity {
+
+    /**
+     * Updates the status of the row corresponding to the given ID.
+     *
+     * @param id        the unique identifier of the row to update.
+     * @param newStatus the new status to set.
+     * @return true if the update was successful, false otherwise.
+     */
+    @ActivityMethod
+    boolean updateStatus(String id, String newStatus);
+}

src/main/java/it/gov/pagopa/payhub/activities/dto/fdr/FdRIngestionResponse.java

@@ -0,0 +1,18 @@
+package it.gov.pagopa.payhub.activities.dto.fdr;
+
+import lombok.AllArgsConstructor;
+import lombok.Data;
+import lombok.NoArgsConstructor;
+
+import java.util.List;
+
+/**
+ * DTO for the FdRIngestionResponse, representing the result of file processing.
+ */
+@Data
+@NoArgsConstructor
+@AllArgsConstructor
+public class FdRIngestionResponse {
+    private List<String> iufList;  // List of extracted IUFs
+    private boolean success;       // Success flag for the operation
+}