diff --git a/src/main/java/it/gov/pagopa/fdr/to/eventhub/util/CommonUtil.java b/src/main/java/it/gov/pagopa/fdr/to/eventhub/util/CommonUtil.java index 298f248..4fb64a1 100644 --- a/src/main/java/it/gov/pagopa/fdr/to/eventhub/util/CommonUtil.java +++ b/src/main/java/it/gov/pagopa/fdr/to/eventhub/util/CommonUtil.java @@ -1,23 +1,5 @@ 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; @@ -31,7 +13,6 @@ 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; @@ -40,8 +21,23 @@ 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 { diff --git a/src/test/java/it/gov/pagopa/fdr/to/eventhub/BlobProcessingFunctionTest.java b/src/test/java/it/gov/pagopa/fdr/to/eventhub/BlobProcessingFunctionTest.java index 54547ab..4f33329 100644 --- a/src/test/java/it/gov/pagopa/fdr/to/eventhub/BlobProcessingFunctionTest.java +++ b/src/test/java/it/gov/pagopa/fdr/to/eventhub/BlobProcessingFunctionTest.java @@ -5,6 +5,7 @@ import static org.junit.jupiter.api.Assertions.assertThrows; import static org.mockito.ArgumentMatchers.any; import static org.mockito.Mockito.atLeastOnce; +import static org.mockito.Mockito.atMost; import static org.mockito.Mockito.doThrow; import static org.mockito.Mockito.lenient; import static org.mockito.Mockito.mock; @@ -98,6 +99,9 @@ void testFDR1BlobTriggerProcessing() throws Exception { // it is verified that the distinct on the dates has left the only expected // date for all payments assertEquals(1, flowEvent.getAllDates().size()); + + ArgumentCaptor> logCaptor = ArgumentCaptor.forClass(Supplier.class); + verify(mockLogger, atMost(2)).info(logCaptor.capture()); } @Test