NOD-690: wip

src/main/java/it/gov/pagopa/node/cfg_sync/EventHubClientApplication.java → src/main/java/it/gov/pagopa/node/cfgsync/EventHubClientApplication.java

@@ -1,4 +1,4 @@
-package it.gov.pagopa.node.cfg_sync;
+package it.gov.pagopa.node.cfgsync;
 
 import com.azure.messaging.eventhubs.EventProcessorClient;
 import org.slf4j.Logger;

src/main/java/it/gov/pagopa/node/cfg_sync/client/ApiConfigCacheClient.java → src/main/java/it/gov/pagopa/node/cfgsync/client/ApiConfigCacheClient.java

@@ -1,4 +1,4 @@
-package it.gov.pagopa.node.cfg_sync.client;
+package it.gov.pagopa.node.cfgsync.client;
 
 import feign.Headers;
 import feign.Param;

src/main/java/it/gov/pagopa/node/cfg_sync/client/StandInManagerClient.java → src/main/java/it/gov/pagopa/node/cfgsync/client/StandInManagerClient.java

@@ -1,4 +1,4 @@
-package it.gov.pagopa.node.cfg_sync.client;
+package it.gov.pagopa.node.cfgsync.client;
 
 import feign.Headers;
 import feign.Param;

src/main/java/it/gov/pagopa/node/cfg_sync/config/EventHubClientConfiguration.java → src/main/java/it/gov/pagopa/node/cfgsync/config/EventHubClientConfiguration.java

@@ -1,8 +1,7 @@
-package it.gov.pagopa.node.cfg_sync.config;
+package it.gov.pagopa.node.cfgsync.config;
 
 import com.azure.identity.DefaultAzureCredentialBuilder;
 import com.azure.messaging.eventhubs.EventHubClientBuilder;
-import com.azure.messaging.eventhubs.EventHubProducerClient;
 import com.azure.messaging.eventhubs.EventProcessorClient;
 import com.azure.messaging.eventhubs.EventProcessorClientBuilder;
 import com.azure.messaging.eventhubs.checkpointstore.blob.BlobCheckpointStore;

src/main/java/it/gov/pagopa/node/cfg_sync/config/EventHubProcessorClientConfiguration.java → src/main/java/it/gov/pagopa/node/cfgsync/config/EventHubProcessorClientConfiguration.java

@@ -1,4 +1,4 @@
-package it.gov.pagopa.node.cfg_sync.config;
+package it.gov.pagopa.node.cfgsync.config;
 
 import com.azure.spring.cloud.service.eventhubs.consumer.EventHubsErrorHandler;
 import com.azure.spring.cloud.service.eventhubs.consumer.EventHubsRecordMessageListener;

src/main/java/it/gov/pagopa/node/cfg_sync/config/LoggingAspect.java → src/main/java/it/gov/pagopa/node/cfgsync/config/LoggingAspect.java

@@ -1,4 +1,4 @@
-package it.gov.pagopa.node.cfg_sync.config;
+package it.gov.pagopa.node.cfgsync.config;
 
 import lombok.extern.slf4j.Slf4j;
 import org.aspectj.lang.JoinPoint;

src/main/java/it/gov/pagopa/node/cfg_sync/config/MappingsConfiguration.java → src/main/java/it/gov/pagopa/node/cfgsync/config/MappingsConfiguration.java

@@ -1,4 +1,4 @@
-package it.gov.pagopa.node.cfg_sync.config;
+package it.gov.pagopa.node.cfgsync.config;
 
 
 import org.modelmapper.ModelMapper;

src/main/java/it/gov/pagopa/node/cfg_sync/config/OpenApiConfig.java → src/main/java/it/gov/pagopa/node/cfgsync/config/OpenApiConfig.java

@@ -1,4 +1,4 @@
-package it.gov.pagopa.node.cfg_sync.config;
+package it.gov.pagopa.node.cfgsync.config;
 
 import io.swagger.v3.oas.models.Components;
 import io.swagger.v3.oas.models.OpenAPI;
@@ -14,7 +14,7 @@
 import java.util.Objects;
 import java.util.Optional;
 
-import it.gov.pagopa.node.cfg_sync.util.Constants;
+import it.gov.pagopa.node.cfgsync.util.Constants;
 import org.springdoc.core.customizers.OpenApiCustomiser;
 import org.springframework.beans.factory.annotation.Value;
 import org.springframework.context.annotation.Bean;

src/main/java/it/gov/pagopa/node/cfg_sync/config/RequestFilter.java → src/main/java/it/gov/pagopa/node/cfgsync/config/RequestFilter.java

@@ -1,4 +1,4 @@
-package it.gov.pagopa.node.cfg_sync.config;
+package it.gov.pagopa.node.cfgsync.config;
 
 import java.io.IOException;
 import java.util.UUID;
@@ -10,7 +10,7 @@
 import javax.servlet.http.HttpServletRequest;
 import javax.servlet.http.HttpServletResponse;
 
-import it.gov.pagopa.node.cfg_sync.util.Constants;
+import it.gov.pagopa.node.cfgsync.util.Constants;
 import lombok.extern.slf4j.Slf4j;
 import org.slf4j.MDC;
 import org.springframework.core.Ordered;

src/main/java/it/gov/pagopa/node/cfg_sync/config/ResponseValidator.java → src/main/java/it/gov/pagopa/node/cfgsync/config/ResponseValidator.java

@@ -1,6 +1,6 @@
-package it.gov.pagopa.node.cfg_sync.config;
+package it.gov.pagopa.node.cfgsync.config;
 
-import it.gov.pagopa.node.cfg_sync.exception.AppException;
+import it.gov.pagopa.node.cfgsync.exception.AppException;
 import java.util.Set;
 import javax.validation.ConstraintViolation;
 import javax.validation.Validator;

src/main/java/it/gov/pagopa/node/cfg_sync/config/WebMvcConfiguration.java → src/main/java/it/gov/pagopa/node/cfgsync/config/WebMvcConfiguration.java

@@ -1,7 +1,7 @@
-package it.gov.pagopa.node.cfg_sync.config;
+package it.gov.pagopa.node.cfgsync.config;
 
 import com.fasterxml.jackson.databind.ObjectMapper;
-import it.gov.pagopa.node.cfg_sync.model.AppCorsConfiguration;
+import it.gov.pagopa.node.cfgsync.model.AppCorsConfiguration;
 import lombok.SneakyThrows;
 import org.springframework.beans.factory.annotation.Value;
 import org.springframework.context.annotation.Configuration;

src/main/java/it/gov/pagopa/node/cfg_sync/controller/HomeController.java → src/main/java/it/gov/pagopa/node/cfgsync/controller/HomeController.java

@@ -1,4 +1,4 @@
-package it.gov.pagopa.node.cfg_sync.controller;
+package it.gov.pagopa.node.cfgsync.controller;
 
 import io.swagger.v3.oas.annotations.Hidden;
 import org.springframework.beans.factory.annotation.Value;

src/main/java/it/gov/pagopa/node/cfg_sync/controller/SyncCacheController.java → src/main/java/it/gov/pagopa/node/cfgsync/controller/SyncCacheController.java

@@ -1,15 +1,15 @@
-package it.gov.pagopa.node.cfg_sync.controller;
+package it.gov.pagopa.node.cfgsync.controller;
 
 import io.swagger.v3.oas.annotations.Operation;
 import io.swagger.v3.oas.annotations.media.Content;
 import io.swagger.v3.oas.annotations.media.Schema;
 import io.swagger.v3.oas.annotations.responses.ApiResponse;
 import io.swagger.v3.oas.annotations.responses.ApiResponses;
 import io.swagger.v3.oas.annotations.security.SecurityRequirement;
-import it.gov.pagopa.node.cfg_sync.model.ProblemJson;
-import it.gov.pagopa.node.cfg_sync.model.RefreshResponse;
-import it.gov.pagopa.node.cfg_sync.model.TargetRefreshEnum;
-import it.gov.pagopa.node.cfg_sync.service.CacheServiceFactory;
+import it.gov.pagopa.node.cfgsync.model.ProblemJson;
+import it.gov.pagopa.node.cfgsync.model.RefreshResponse;
+import it.gov.pagopa.node.cfgsync.model.TargetRefreshEnum;
+import it.gov.pagopa.node.cfgsync.service.CacheServiceFactory;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.http.HttpHeaders;
@@ -21,7 +21,6 @@
 import org.springframework.web.bind.annotation.RequestMapping;
 import org.springframework.web.bind.annotation.RestController;
 
-import java.io.IOException;
 import java.time.ZonedDateTime;
 import java.time.format.DateTimeFormatter;
 import java.util.UUID;

src/main/java/it/gov/pagopa/node/cfg_sync/exception/AppError.java → src/main/java/it/gov/pagopa/node/cfgsync/exception/AppError.java

@@ -1,4 +1,4 @@
-package it.gov.pagopa.node.cfg_sync.exception;
+package it.gov.pagopa.node.cfgsync.exception;
 
 import lombok.Getter;
 import org.springframework.http.HttpStatus;

src/main/java/it/gov/pagopa/node/cfg_sync/exception/AppException.java → src/main/java/it/gov/pagopa/node/cfgsync/exception/AppException.java

@@ -1,4 +1,4 @@
-package it.gov.pagopa.node.cfg_sync.exception;
+package it.gov.pagopa.node.cfgsync.exception;
 
 import java.util.Formatter;
 import javax.validation.constraints.NotNull;

src/main/java/it/gov/pagopa/node/cfg_sync/exception/ErrorHandler.java → src/main/java/it/gov/pagopa/node/cfgsync/exception/ErrorHandler.java

@@ -1,6 +1,6 @@
-package it.gov.pagopa.node.cfg_sync.exception;
+package it.gov.pagopa.node.cfgsync.exception;
 
-import it.gov.pagopa.node.cfg_sync.model.ProblemJson;
+import it.gov.pagopa.node.cfgsync.model.ProblemJson;
 import java.util.ArrayList;
 import java.util.List;
 

src/main/java/it/gov/pagopa/node/cfg_sync/model/AppCorsConfiguration.java → src/main/java/it/gov/pagopa/node/cfgsync/model/AppCorsConfiguration.java

@@ -1,4 +1,4 @@
-package it.gov.pagopa.node.cfg_sync.model;
+package it.gov.pagopa.node.cfgsync.model;
 
 import com.fasterxml.jackson.annotation.JsonIgnoreProperties;
 import com.fasterxml.jackson.annotation.JsonInclude;

src/main/java/it/gov/pagopa/node/cfg_sync/model/AppInfo.java → src/main/java/it/gov/pagopa/node/cfgsync/model/AppInfo.java

@@ -1,4 +1,4 @@
-package it.gov.pagopa.node.cfg_sync.model;
+package it.gov.pagopa.node.cfgsync.model;
 
 import com.fasterxml.jackson.annotation.JsonIgnoreProperties;
 import lombok.AccessLevel;

src/main/java/it/gov/pagopa/node/cfg_sync/model/ProblemJson.java → src/main/java/it/gov/pagopa/node/cfgsync/model/ProblemJson.java

@@ -1,4 +1,4 @@
-package it.gov.pagopa.node.cfg_sync.model;
+package it.gov.pagopa.node.cfgsync.model;
 
 import com.fasterxml.jackson.annotation.JsonIgnoreProperties;
 import com.fasterxml.jackson.annotation.JsonProperty;

src/main/java/it/gov/pagopa/node/cfg_sync/model/RefreshResponse.java → src/main/java/it/gov/pagopa/node/cfgsync/model/RefreshResponse.java

@@ -1,4 +1,4 @@
-package it.gov.pagopa.node.cfg_sync.model;
+package it.gov.pagopa.node.cfgsync.model;
 
 import com.fasterxml.jackson.annotation.JsonIgnoreProperties;
 import lombok.*;

src/main/java/it/gov/pagopa/node/cfg_sync/model/TargetRefreshEnum.java → src/main/java/it/gov/pagopa/node/cfgsync/model/TargetRefreshEnum.java

@@ -1,4 +1,4 @@
-package it.gov.pagopa.node.cfg_sync.model;
+package it.gov.pagopa.node.cfgsync.model;
 
 public enum TargetRefreshEnum {
 

src/main/java/it/gov/pagopa/node/cfg_sync/repository/config/NodoONexiConfiguration.java → src/main/java/it/gov/pagopa/node/cfgsync/repository/config/NodoONexiConfiguration.java

@@ -1,4 +1,4 @@
-package it.gov.pagopa.node.cfg_sync.repository.config;
+package it.gov.pagopa.node.cfgsync.repository.config;
 
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.context.annotation.*;

src/main/java/it/gov/pagopa/node/cfg_sync/repository/config/NodoPagoPAPConfiguration.java → src/main/java/it/gov/pagopa/node/cfgsync/repository/config/NodoPagoPAPConfiguration.java

@@ -1,4 +1,4 @@
-package it.gov.pagopa.node.cfg_sync.repository.config;
+package it.gov.pagopa.node.cfgsync.repository.config;
 
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.context.annotation.*;

src/main/java/it/gov/pagopa/node/cfg_sync/repository/model/Cache.java → src/main/java/it/gov/pagopa/node/cfgsync/repository/model/Cache.java

@@ -1,8 +1,6 @@
-package it.gov.pagopa.node.cfg_sync.repository.model;
+package it.gov.pagopa.node.cfgsync.repository.model;
 
-import antlr.ANTLRParser;
 import lombok.AllArgsConstructor;
-import lombok.Builder;
 import lombok.NoArgsConstructor;
 
 import javax.persistence.Column;

src/main/java/it/gov/pagopa/node/cfgsync/repository/model/nexi/CacheNexiOracle.java

@@ -0,0 +1,15 @@
+package it.gov.pagopa.node.cfgsync.repository.model.nexi;
+
+import it.gov.pagopa.node.cfgsync.repository.model.Cache;
+import lombok.*;
+
+import javax.persistence.Entity;
+import javax.persistence.Table;
+
+@Getter
+@Setter
+@Entity
+@Table(name = "cache")
+public class CacheNexiOracle extends Cache {
+
+}

src/main/java/it/gov/pagopa/node/cfgsync/repository/model/pagopa/CachePagoPA.java

@@ -0,0 +1,15 @@
+package it.gov.pagopa.node.cfgsync.repository.model.pagopa;
+
+import it.gov.pagopa.node.cfgsync.repository.model.Cache;
+import lombok.*;
+
+import javax.persistence.Entity;
+import javax.persistence.Table;
+
+@Getter
+@Setter
+@Entity
+@Table(name = "cache")
+public class CachePagoPA extends Cache {
+
+}

src/main/java/it/gov/pagopa/node/cfg_sync/repository/nexi/CacheNodoONexiRepository.java → src/main/java/it/gov/pagopa/node/cfgsync/repository/nexi/CacheNodoONexiRepository.java

@@ -1,6 +1,6 @@
-package it.gov.pagopa.node.cfg_sync.repository.nexi;
+package it.gov.pagopa.node.cfgsync.repository.nexi;
 
-import it.gov.pagopa.node.cfg_sync.repository.model.nexi.CacheNexiOracle;
+import it.gov.pagopa.node.cfgsync.repository.model.nexi.CacheNexiOracle;
 import org.springframework.data.jpa.repository.JpaRepository;
 import org.springframework.stereotype.Repository;
 

src/main/java/it/gov/pagopa/node/cfg_sync/repository/pagopa/CacheNodoPagoPAPRepository.java → src/main/java/it/gov/pagopa/node/cfgsync/repository/pagopa/CacheNodoPagoPAPRepository.java

@@ -1,6 +1,6 @@
-package it.gov.pagopa.node.cfg_sync.repository.pagopa;
+package it.gov.pagopa.node.cfgsync.repository.pagopa;
 
-import it.gov.pagopa.node.cfg_sync.repository.model.pagopa.CachePagoPA;
+import it.gov.pagopa.node.cfgsync.repository.model.pagopa.CachePagoPA;
 import org.springframework.data.jpa.repository.JpaRepository;
 import org.springframework.stereotype.Repository;
 

src/main/java/it/gov/pagopa/node/cfg_sync/service/ApiConfigCacheService.java → src/main/java/it/gov/pagopa/node/cfgsync/service/ApiConfigCacheService.java

@@ -1,15 +1,14 @@
-package it.gov.pagopa.node.cfg_sync.service;
+package it.gov.pagopa.node.cfgsync.service;
 
 import feign.Feign;
 import feign.FeignException;
 import feign.Response;
-import it.gov.pagopa.node.cfg_sync.client.ApiConfigCacheClient;
-import it.gov.pagopa.node.cfg_sync.exception.AppError;
-import it.gov.pagopa.node.cfg_sync.exception.AppException;
-import it.gov.pagopa.node.cfg_sync.model.TargetRefreshEnum;
-import it.gov.pagopa.node.cfg_sync.repository.model.Cache;
-import it.gov.pagopa.node.cfg_sync.repository.model.pagopa.CachePagoPA;
-import it.gov.pagopa.node.cfg_sync.repository.pagopa.CacheNodoPagoPAPRepository;
+import it.gov.pagopa.node.cfgsync.client.ApiConfigCacheClient;
+import it.gov.pagopa.node.cfgsync.exception.AppError;
+import it.gov.pagopa.node.cfgsync.exception.AppException;
+import it.gov.pagopa.node.cfgsync.model.TargetRefreshEnum;
+import it.gov.pagopa.node.cfgsync.repository.model.pagopa.CachePagoPA;
+import it.gov.pagopa.node.cfgsync.repository.pagopa.CacheNodoPagoPAPRepository;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.beans.factory.annotation.Value;

src/main/java/it/gov/pagopa/node/cfgsync/service/CacheService.java

@@ -0,0 +1,9 @@
+package it.gov.pagopa.node.cfgsync.service;
+
+import it.gov.pagopa.node.cfgsync.model.TargetRefreshEnum;
+
+public interface CacheService {
+
+    TargetRefreshEnum getType();
+    void syncCache();
+}

src/main/java/it/gov/pagopa/node/cfg_sync/service/CacheServiceFactory.java → src/main/java/it/gov/pagopa/node/cfgsync/service/CacheServiceFactory.java

@@ -1,6 +1,6 @@
-package it.gov.pagopa.node.cfg_sync.service;
+package it.gov.pagopa.node.cfgsync.service;
 
-import it.gov.pagopa.node.cfg_sync.model.TargetRefreshEnum;
+import it.gov.pagopa.node.cfgsync.model.TargetRefreshEnum;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
 

src/main/java/it/gov/pagopa/node/cfg_sync/service/CommonCacheService.java → src/main/java/it/gov/pagopa/node/cfgsync/service/CommonCacheService.java

@@ -1,10 +1,10 @@
-package it.gov.pagopa.node.cfg_sync.service;
+package it.gov.pagopa.node.cfgsync.service;
 
-import it.gov.pagopa.node.cfg_sync.exception.AppError;
-import it.gov.pagopa.node.cfg_sync.exception.AppException;
-import it.gov.pagopa.node.cfg_sync.model.TargetRefreshEnum;
-import it.gov.pagopa.node.cfg_sync.repository.model.Cache;
-import it.gov.pagopa.node.cfg_sync.util.Utils;
+import it.gov.pagopa.node.cfgsync.exception.AppError;
+import it.gov.pagopa.node.cfgsync.exception.AppException;
+import it.gov.pagopa.node.cfgsync.model.TargetRefreshEnum;
+import it.gov.pagopa.node.cfgsync.repository.model.Cache;
+import it.gov.pagopa.node.cfgsync.util.Utils;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.beans.factory.annotation.Value;
 

src/main/java/it/gov/pagopa/node/cfg_sync/service/StandInManagerCacheService.java → src/main/java/it/gov/pagopa/node/cfgsync/service/StandInManagerCacheService.java

@@ -1,11 +1,11 @@
-package it.gov.pagopa.node.cfg_sync.service;
+package it.gov.pagopa.node.cfgsync.service;
 
 import feign.Feign;
 import feign.FeignException;
-import it.gov.pagopa.node.cfg_sync.client.StandInManagerClient;
-import it.gov.pagopa.node.cfg_sync.exception.AppError;
-import it.gov.pagopa.node.cfg_sync.exception.AppException;
-import it.gov.pagopa.node.cfg_sync.model.TargetRefreshEnum;
+import it.gov.pagopa.node.cfgsync.client.StandInManagerClient;
+import it.gov.pagopa.node.cfgsync.exception.AppError;
+import it.gov.pagopa.node.cfgsync.exception.AppException;
+import it.gov.pagopa.node.cfgsync.model.TargetRefreshEnum;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.beans.factory.annotation.Value;
 import org.springframework.stereotype.Component;

src/main/java/it/gov/pagopa/node/cfg_sync/util/Constants.java → src/main/java/it/gov/pagopa/node/cfgsync/util/Constants.java

@@ -1,4 +1,4 @@
-package it.gov.pagopa.node.cfg_sync.util;
+package it.gov.pagopa.node.cfgsync.util;
 
 import lombok.experimental.UtilityClass;
 

src/main/java/it/gov/pagopa/node/cfg_sync/util/Utils.java → src/main/java/it/gov/pagopa/node/cfgsync/util/Utils.java

@@ -1,4 +1,4 @@
-package it.gov.pagopa.node.cfg_sync.util;
+package it.gov.pagopa.node.cfgsync.util;
 
 import javax.persistence.Column;
 import java.io.ByteArrayOutputStream;

src/test/java/it/gov/pagopa/node/cfg_sync/ApplicationTest.java → src/test/java/it/gov/pagopa/node/cfgsync/ApplicationTest.java

@@ -1,4 +1,4 @@
-package it.gov.pagopa.node.cfg_sync;
+package it.gov.pagopa.node.cfgsync;
 
 import static org.junit.jupiter.api.Assertions.assertTrue;