feat: new function to report

.env.sample

@@ -9,4 +9,6 @@ NODO_HOST=http://localhost:8086/nodo-per-pa/v1
 PAA_ID_INTERMEDIARIO=PAA_ID_INTERMEDIARIO
 PAA_STAZIONE_INT=PAA_STAZIONE_INT
 PAA_PASSWORD=PAA_PASSWORD
-NCRON_SCHEDULE_BATCH=*/45 * * * * *
+NCRON_SCHEDULE_BATCH=*/45 * * * * *
+GPD_BASE_PATH=https://api.dev.platform.pagopa.it/gpd/api/v2
+GPD_SUBKEY=GPD_SUBKEY

.identity/00_data.tf

@@ -1,12 +1,3 @@
-data "azurerm_resource_group" "dashboards" {
-  name = "dashboards"
-}
-
-data "azurerm_kubernetes_cluster" "aks" {
-  name                = local.aks_cluster.name
-  resource_group_name = local.aks_cluster.resource_group_name
-}
-
 data "github_organization_teams" "all" {
   root_teams_only = true
   summary_only    = true
@@ -42,12 +33,6 @@ data "azurerm_key_vault_secret" "key_vault_integration_test_subkey" {
   key_vault_id = data.azurerm_key_vault.key_vault.id
 }
 
-data "azurerm_key_vault_secret" "flow_sa_connection_string" {
-  name         = "flows-sa-${var.env_short}-connection-string"
-  key_vault_id = data.azurerm_key_vault.domain_key_vault.id
-}
-
-
 data "azurerm_user_assigned_identity" "identity_cd_01"{
   name = "${local.prefix}-${var.env_short}-${local.domain}-01-github-cd-identity"
   resource_group_name = "${local.prefix}-${var.env_short}-identity-rg"

.identity/03_github_environment.tf

@@ -25,15 +25,13 @@ locals {
     "TENANT_ID" : data.azurerm_client_config.current.tenant_id,
     "SUBSCRIPTION_ID" : data.azurerm_subscription.current.subscription_id,
     "API_SUBSCRIPTION_KEY" : data.azurerm_key_vault_secret.key_vault_integration_test_subkey.value,
-    "FLOW_SA_CONNECTION_STRING": data.azurerm_key_vault_secret.flow_sa_connection_string.value
   }
   env_variables = {
     "CONTAINER_APP_ENVIRONMENT_NAME" : local.container_app_environment.name,
     "CONTAINER_APP_ENVIRONMENT_RESOURCE_GROUP_NAME" : local.container_app_environment.resource_group,
     "CLUSTER_NAME" : local.aks_cluster.name,
     "CLUSTER_RESOURCE_GROUP" : local.aks_cluster.resource_group_name,
     "NAMESPACE" : local.domain,
-    "REPORTING_BATCH_QUEUE": "pagopa${var.env_short}flowsaqueueorg"
   }
   repo_secrets = {
     "SONAR_TOKEN" : data.azurerm_key_vault_secret.key_vault_sonar.value,

.pre-commit-config.yaml

@@ -4,8 +4,8 @@
 # more info https://docs.gitguardian.com/internal-repositories-monitoring/integrations/git_hooks/pre_commit
 repos:
   - repo: https://github.com/gitguardian/ggshield
-    rev: v1.11.0
+    rev: v1.40.0
     hooks:
       - id: ggshield
         language_version: python3
-        stages: [ commit ]
+        stages: [ pre-commit ]

local.settings.json.example

@@ -13,6 +13,8 @@
       "NODO_HOST": "http://localhost:8081/nodo-per-pa/v1",
       "PAA_ID_INTERMEDIARIO":"PAA_ID_INTERMEDIARIO",
       "PAA_STAZIONE_INT":"PAA_STAZIONE_INT",
-      "PAA_PASSWORD":"PAA_PASSWORD"
+      "PAA_PASSWORD":"PAA_PASSWORD",
+      "GPD_BASE_PATH":"https://api.dev.platform.pagopa.it/gpd/api/v2",
+      "GPD_SUBKEY": "GPD_SUBKEY"
     }
   }

pom.xml

@@ -108,6 +108,12 @@
             <version>2.3.1</version>
         </dependency>
 
+        <dependency>
+            <groupId>com.mashape.unirest</groupId>
+            <artifactId>unirest-java</artifactId>
+            <version>1.4.9</version>
+        </dependency>
+
         <!-- resteasy START -->
         <dependency>
             <groupId>org.jboss.resteasy</groupId>

src/main/java/it/gov/pagopa/reporting/GpdReportingSync.java

@@ -0,0 +1,61 @@
+package it.gov.pagopa.reporting;
+
+import com.mashape.unirest.http.HttpResponse;
+import com.mashape.unirest.http.Unirest;
+import com.microsoft.azure.functions.*;
+import com.microsoft.azure.functions.annotation.*;
+import it.gov.pagopa.reporting.model.ReportedIUVEventModel;
+
+import java.time.LocalDateTime;
+import java.util.List;
+import java.util.Map;
+import java.util.logging.Level;
+import java.util.logging.Logger;
+
+/**
+ * Azure Functions with Azure Http trigger.
+ */
+public class GpdReportingSync {
+
+    private String gpdBasePath = System.getenv("GPD_BASE_PATH");
+    private String gpdSubeKey = System.getenv("GPD_SUBKEY");
+
+
+    /**
+     * This function will be invoked by an incoming HTTP request
+     * @return
+     */
+    @FunctionName("GpdReportingSync")
+    public void run (
+            @EventHubTrigger(
+                    name = "BizEvent",
+                    eventHubName = "", // blank because the value is included in the connection string
+                    connection = "FDR_EVENTHUB_CONN_STRING",
+                    cardinality = Cardinality.MANY)
+            List<ReportedIUVEventModel> items,
+            @BindingName(value = "PropertiesArray") Map<String, Object>[] properties,
+            final ExecutionContext context) {
+
+        Logger logger = context.getLogger();
+        logger.log(Level.FINE, () -> "[GpdReportingSync] function executed at: " + LocalDateTime.now());
+
+        for (ReportedIUVEventModel event: items) {
+            gpdReport(logger, event.getDomainId(), event.getIuv(), String.valueOf(event.getIdTransfer()));
+        }
+
+    }
+
+    public  void gpdReport(Logger logger, String organizationId, String iuv, String transferId) {
+        try {
+            HttpResponse<String> response = Unirest.post(gpdBasePath + "/organizations/" + organizationId + "/paymentoptions/" + iuv + "/transfers/" + transferId + "/report")
+                    .header("accept", "application/json")
+                    .header("ocp-apim-subscription-key", gpdSubeKey)
+                    .asString();
+            logger.log(Level.INFO, () -> response.getStatus() +" "+ response.getBody()); // TODO delete this line
+        } catch (Exception e) {
+            logger.log(Level.SEVERE, () -> "[GpdReportingSync] GPD client error: " + e.getLocalizedMessage());
+        }
+    }
+
+
+}

src/main/java/it/gov/pagopa/reporting/model/ReportedIUVEventModel.java

@@ -0,0 +1,58 @@
+package it.gov.pagopa.reporting.model;
+
+import com.fasterxml.jackson.annotation.JsonProperty;
+import java.math.BigDecimal;
+import java.time.LocalDateTime;
+import lombok.AllArgsConstructor;
+import lombok.Builder;
+import lombok.Data;
+import lombok.NoArgsConstructor;
+
+@Data
+@NoArgsConstructor
+@AllArgsConstructor
+@Builder
+public class ReportedIUVEventModel {
+
+    @JsonProperty("IUV")
+    private String iuv;
+
+    @JsonProperty("IUR")
+    private String iur;
+
+    @JsonProperty("IMPORTO")
+    private BigDecimal amount;
+
+    @JsonProperty("COD_ESITO")
+    private Integer outcomeCode;
+
+    @JsonProperty("DATA_ESITO_SINGOLO_PAGAMENTO")
+    private LocalDateTime singlePaymentOutcomeDate;
+
+    @JsonProperty("IDSP")
+    private String idsp;
+
+    @JsonProperty("ID_FLUSSO")
+    private String flowId;
+
+    @JsonProperty("DATA_ORA_FLUSSO")
+    private LocalDateTime flowDateTime;
+
+    @JsonProperty("ID_DOMINIO")
+    private String domainId;
+
+    @JsonProperty("PSP")
+    private String psp;
+
+    @JsonProperty("INT_PSP")
+    private String intPsp;
+
+    @JsonProperty("UNIQUE_ID")
+    private String uniqueId;
+
+    @JsonProperty("INSERTED_TIMESTAMP")
+    private LocalDateTime insertedTimestamp;
+
+    @JsonProperty("ID_TRANSFER")
+    private Long idTransfer;
+}