[PAGOPA-2686] opex: Add error-codes

helm/Chart.yaml

@@ -2,8 +2,8 @@ apiVersion: v2
 name: pagopa-fdr-to-event-hub
 description: Microservice fdr to event hub
 type: application
-version: 0.50.0
-appVersion: 1.0.0
+version: 0.57.0
+appVersion: 1.0.0-7-PAGOPA-2686
 dependencies:
   - name: microservice-chart
     version: 7.1.1

helm/values-dev.yaml

@@ -4,7 +4,7 @@ microservice-chart:
   fullnameOverride: "pagopa-fdr-2-event-hub"
   image:
     repository: ghcr.io/pagopa/pagopa-fdr-2-event-hub
-    tag: "1.0.0"
+    tag: "1.0.0-7-PAGOPA-2686"
     pullPolicy: Always
   # https://github.com/Azure/azure-functions-host/blob/dev/src/WebJobs.Script.WebHost/Controllers/HostController.cs
   # livenessProbe:

helm/values-prod.yaml

@@ -4,7 +4,7 @@ microservice-chart:
   fullnameOverride: "pagopa-fdr-2-event-hub"
   image:
     repository: ghcr.io/pagopa/pagopa-fdr-2-event-hub
-    tag: "1.0.0"
+    tag: "1.0.0-7-PAGOPA-2686"
     pullPolicy: Always
   # https://github.com/Azure/azure-functions-host/blob/dev/src/WebJobs.Script.WebHost/Controllers/HostController.cs
   # livenessProbe:

helm/values-uat.yaml

@@ -4,7 +4,7 @@ microservice-chart:
   fullnameOverride: "pagopa-fdr-2-event-hub"
   image:
     repository: ghcr.io/pagopa/pagopa-fdr-2-event-hub
-    tag: "1.0.0"
+    tag: "1.0.0-7-PAGOPA-2686"
     pullPolicy: Always
   # https://github.com/Azure/azure-functions-host/blob/dev/src/WebJobs.Script.WebHost/Controllers/HostController.cs
   # livenessProbe:

host.json

@@ -31,9 +31,9 @@
     "logLevel": {
       "default": "None",
       "Host.Results": "Error",
-      "Function.ProcessFDR1BlobFiles": "Information",
-      "Function.ProcessFDR3BlobFiles": "Information",
-      "Function.HTTPBlobRecovery": "Information",
+      "Function.ProcessFDR1BlobFiles": "Warning",
+      "Function.ProcessFDR3BlobFiles": "Warning",
+      "Function.HTTPBlobRecovery": "Warning",
       "Host.Aggregator": "Error"
     },
     "applicationInsights": {

pom.xml

@@ -6,7 +6,7 @@
 
 	<groupId>it.gov.pagopa.fdr.to.eventhub</groupId>
 	<artifactId>pagopa-fdr-to-event-hub</artifactId>
-	<version>1.0.0</version>
+	<version>1.0.0-7-PAGOPA-2686</version>
 	<packaging>jar</packaging>
 
 	<name>FDR To Event Hub</name>
@@ -22,8 +22,7 @@
 		<azure.messaging.eventhubs.version>5.20.0
 		</azure.messaging.eventhubs.version>
 		<azure.storage.blob.version>12.29.0</azure.storage.blob.version>
-		<functionAppName>com.microsoft.azure-20220215182005862
-		</functionAppName>
+		<functionAppName>com.microsoft.azure-20220215182005862</functionAppName>
 		<jackson.version>2.18.2</jackson.version>
 		<modelmapper.version>3.2.2</modelmapper.version>
 		<lombok.version>1.18.36</lombok.version>

src/main/java/it/gov/pagopa/fdr/to/eventhub/BlobProcessingFunction.java

@@ -13,6 +13,8 @@
 import java.time.LocalDateTime;
 import java.time.format.DateTimeFormatter;
 import java.util.Map;
+
+import it.gov.pagopa.fdr.to.eventhub.util.ErrorCodes;
 import lombok.Getter;
 
 public class BlobProcessingFunction {
@@ -74,7 +76,7 @@ public synchronized void processFDR1BlobFiles(
 
     context
         .getLogger()
-        .info(
+        .fine(
             () ->
                 String.format(
                     "[FDR1] Triggered at: %s for Blob container: %s, name: %s, size in bytes: %d",
@@ -117,7 +119,7 @@ public synchronized void processFDR1BlobFiles(
 
       context
           .getLogger()
-          .info(
+          .fine(
               () ->
                   String.format(
                       "[FDR1] Execution Finished at: %s for Blob container: %s, name: %s, size in"
@@ -134,8 +136,8 @@ public synchronized void processFDR1BlobFiles(
           .severe(
               () ->
                   String.format(
-                      "[FDR1] Error processing Blob '%s/%s': %s",
-                      fdr1Container, blobName, e.getMessage()));
+                      "[%s][FDR1] Error processing Blob '%s/%s': %s",
+                          ErrorCodes.FDR1_E1, fdr1Container, blobName, e.getMessage()));
     }
   }
 
@@ -153,15 +155,15 @@ public void processFDR3BlobFiles(
 
     context
         .getLogger()
-        .info(
+        .fine(
             () ->
                 String.format(
                     "[FDR3] Triggered for Blob container: %s, name: %s, size: %d bytes",
                     fdr3Container, blobName, content.length));
 
     context
         .getLogger()
-        .info(
+        .fine(
             () ->
                 String.format(
                     "[FDR3] Execution Finished at: %s for Blob container: %s, name: %s, size: %d"

src/main/java/it/gov/pagopa/fdr/to/eventhub/HttpBlobRecoveryFunction.java

@@ -83,7 +83,7 @@ public HttpResponseMessage run(
 
       context
           .getLogger()
-          .info(
+          .fine(
               () ->
                   String.format(
                       "[HTTP FDR] Triggered at: %s for Blob container: %s, name: %s",

src/main/java/it/gov/pagopa/fdr/to/eventhub/util/CommonUtil.java

@@ -164,8 +164,8 @@ public static boolean processXmlBlobAndSendToEventHub(
       // Log the exception with context
       String errorMessage =
           String.format(
-              "Error processing or sending data to event hub: %s. Details: %s",
-              flussoRendicontazione.getIdentificativoFlusso(), e.getMessage());
+              "[%s] Error processing or sending data to event hub: %s. Details: %s",
+              ErrorCodes.COMMON_E2, flussoRendicontazione.getIdentificativoFlusso(), e.getMessage());
       context.getLogger().severe(() -> errorMessage);
 
       return false;
@@ -241,11 +241,11 @@ private boolean sendEventToHub(
     } catch (Exception e) {
       context
           .getLogger()
-          .warning(
+          .severe(
               () ->
                   String.format(
-                      "Failed to add event to batch for flow ID: %s. Details: %s",
-                      flusso.getIdentificativoFlusso(), e.getMessage()));
+                      "[%s] Failed to add event to batch for flow ID: %s. Details: %s",
+                      ErrorCodes.COMMON_E1, flusso.getIdentificativoFlusso(), e.getMessage()));
       return false;
     }
   }

src/main/java/it/gov/pagopa/fdr/to/eventhub/util/ErrorCodes.java

@@ -0,0 +1,22 @@
+package it.gov.pagopa.fdr.to.eventhub.util;
+
+import lombok.Getter;
+
+@Getter
+public enum ErrorCodes {
+    // Common Errors
+    COMMON_E1("FDR-E1", "Error while sending to EventHub."),
+    COMMON_E2("FDR-E2", "Error while process XML Blob."),
+    // FDR1 Errors
+    FDR1_E1("FDR1-E1", "Error processing Blob in processFDR1BlobFiles function");
+
+
+    private final String code;
+    private final String message;
+
+    ErrorCodes(String code, String message) {
+        this.code = code;
+        this.message = message;
+    }
+
+}