Skip to content

Commit

Permalink
[PAGOPA-2619] FDR1 recovery blob: coverage exclusion
Browse files Browse the repository at this point in the history
  • Loading branch information
alessio-acitelli committed Feb 25, 2025
2 parents a3e5788 + 05fc57d commit 33d4261
Show file tree
Hide file tree
Showing 2 changed files with 20 additions and 24 deletions.
2 changes: 1 addition & 1 deletion .github/workflows/code_review.yml
Original file line number Diff line number Diff line change
Expand Up @@ -41,7 +41,7 @@ jobs:
sonar_token: ${{ secrets.SONAR_TOKEN }}
project_key: ${{env.PROJECT_KEY}}
java_version: 17
coverage_exclusions: "**/config/*,**/*Mock*,**/models/**,**/clients/model/**,**/entity/*,**/exception/**,**/App.java"
coverage_exclusions: "**/config/*,**/*Mock*,**/models/**,**/clients/model/**,**/entity/*,**/exception/**,**/App.java,**/wrapper/BlobServiceClientWrapperImpl.java"
cpd_exclusions: "**/models/**,**/clients/model/**,**/entity/*"
coverage_report_path: "./target/jacoco-report/jacoco.xml"

Expand Down
42 changes: 19 additions & 23 deletions src/main/java/it/gov/pagopa/fdr/to/eventhub/util/CommonUtil.java
Original file line number Diff line number Diff line change
@@ -1,5 +1,23 @@
package it.gov.pagopa.fdr.to.eventhub.util;

import java.io.ByteArrayInputStream;
import java.io.ByteArrayOutputStream;
import java.io.IOException;
import java.io.InputStream;
import java.nio.charset.StandardCharsets;
import java.time.Duration;
import java.time.LocalDateTime;
import java.time.format.DateTimeFormatter;
import java.util.ArrayList;
import java.util.List;
import java.util.Map;
import java.util.concurrent.atomic.AtomicInteger;
import java.util.zip.GZIPInputStream;

import javax.xml.parsers.ParserConfigurationException;

import org.xml.sax.SAXException;

import com.azure.core.amqp.AmqpRetryMode;
import com.azure.core.amqp.AmqpRetryOptions;
import com.azure.messaging.eventhubs.EventData;
Expand All @@ -13,6 +31,7 @@
import com.fasterxml.jackson.databind.json.JsonMapper;
import com.fasterxml.jackson.datatype.jsr310.JavaTimeModule;
import com.microsoft.azure.functions.ExecutionContext;

import it.gov.pagopa.fdr.to.eventhub.mapper.FlussoRendicontazioneMapper;
import it.gov.pagopa.fdr.to.eventhub.model.BlobFileData;
import it.gov.pagopa.fdr.to.eventhub.model.FlussoRendicontazione;
Expand All @@ -21,23 +40,8 @@
import it.gov.pagopa.fdr.to.eventhub.parser.FDR1XmlSAXParser;
import it.gov.pagopa.fdr.to.eventhub.wrapper.BlobServiceClientWrapper;
import it.gov.pagopa.fdr.to.eventhub.wrapper.BlobServiceClientWrapperImpl;
import java.io.ByteArrayInputStream;
import java.io.ByteArrayOutputStream;
import java.io.IOException;
import java.io.InputStream;
import java.nio.charset.StandardCharsets;
import java.time.Duration;
import java.time.LocalDateTime;
import java.time.format.DateTimeFormatter;
import java.util.ArrayList;
import java.util.List;
import java.util.Map;
import java.util.concurrent.atomic.AtomicInteger;
import java.util.zip.GZIPInputStream;
import javax.xml.parsers.ParserConfigurationException;
import lombok.Setter;
import lombok.experimental.UtilityClass;
import org.xml.sax.SAXException;

@UtilityClass
public class CommonUtil {
Expand Down Expand Up @@ -112,14 +116,6 @@ public static BlobFileData getBlobFile(
}
}

// public static BlobContainerClient getBlobContainerClient(String
// storageEnvVar,
// String container) {

// return new BlobServiceClientWrapperImpl()
// .getBlobContainerClient(storageEnvVar, container);
// }

public static boolean processXmlBlobAndSendToEventHub(
final EventHubProducerClient eventHubClientFlowTx,
final EventHubProducerClient eventHubClientReportedIUV,
Expand Down

0 comments on commit 33d4261

Please sign in to comment.