From 7d6e4ad3d2d515a4c46874da75e3fab7a5288aa3 Mon Sep 17 00:00:00 2001 From: giomella Date: Thu, 26 Sep 2024 16:14:31 +0200 Subject: [PATCH] update station mapper with OdP fields --- .../ConvertStazioniToStationDetails.java | 148 +++++++++--------- 1 file changed, 75 insertions(+), 73 deletions(-) diff --git a/src/main/java/it/gov/pagopa/apiconfig/cache/util/mapper/ConvertStazioniToStationDetails.java b/src/main/java/it/gov/pagopa/apiconfig/cache/util/mapper/ConvertStazioniToStationDetails.java index 76b4faa9..89932df6 100644 --- a/src/main/java/it/gov/pagopa/apiconfig/cache/util/mapper/ConvertStazioniToStationDetails.java +++ b/src/main/java/it/gov/pagopa/apiconfig/cache/util/mapper/ConvertStazioniToStationDetails.java @@ -8,79 +8,81 @@ public class ConvertStazioniToStationDetails implements Converter { - @Override - public Station convert(MappingContext context) { - Stazioni source = context.getSource(); - Proxy proxy = null; + @Override + public Station convert(MappingContext context) { + Stazioni source = context.getSource(); + Proxy proxy = null; - if (Boolean.TRUE.equals(source.getProxyEnabled())) { - proxy = - Proxy.builder() - .proxyHost(source.getProxyHost()) - .proxyPort(source.getProxyPort()) - .proxyUsername(source.getProxyUsername()) - .proxyPassword(source.getProxyPassword()) - .build(); - } + if (Boolean.TRUE.equals(source.getProxyEnabled())) { + proxy = + Proxy.builder() + .proxyHost(source.getProxyHost()) + .proxyPort(source.getProxyPort()) + .proxyUsername(source.getProxyUsername()) + .proxyPassword(source.getProxyPassword()) + .build(); + } - return Station.builder() - .stationCode(source.getIdStazione()) - .enabled(source.getEnabled()) - .version(source.getVersione()) - .password(source.getPassword()) - .connection( - Connection.builder() - .protocol(Protocol.fromValue(source.getProtocollo())) - .ip(source.getIp()) - .port(source.getPorta()) - .build()) - .service( - Service.builder() - .path(source.getServizio()) - .targetHost(source.getTargetHost()) - .targetPort(source.getTargetPort()) - .targetPath(source.getTargetPath()) - .build()) - .pofService( - Service.builder() - .path(source.getServizioPof()) - .targetHost(source.getTargetHostPof()) - .targetPort(source.getTargetPortPof()) - .targetPath(source.getTargetPathPof()) - .build()) - .mod4Service( - Service.builder() - .path(source.getServizio4Mod()) - .targetHost(source.getTargetHost()) - .targetPort(source.getTargetPort()) - .targetPath(source.getTargetPath()) - .build()) - .mod4connection( - Connection.builder() - .protocol(Protocol.fromValue(source.getProtocollo4Mod())) - .ip(source.getIp4Mod()) - .port(source.getPorta4Mod()) - .build()) - .brokerCode(source.getIntermediarioPa().getIdIntermediarioPa()) - .redirect( - Redirect.builder() - .protocol(Protocol.fromValue(source.getRedirectProtocollo())) - .ip(source.getRedirectIp()) - .port(source.getRedirectPorta()) - .path(source.getRedirectPath()) - .queryString(source.getRedirectQueryString()) - .build()) - .proxy(proxy) - .threadNumber(source.getNumThread()) - .timeouts( - Timeouts.builder() - .timeoutA(source.getTimeoutA()) - .timeoutB(source.getTimeoutB()) - .timeoutC(source.getTimeoutC()) - .build()) - .rtInstantaneousDispatch(source.getInvioRtIstantaneo()) - .primitiveVersion(source.getVersionePrimitive()) - .flagStandIn(source.getFlagStandin()) - .build(); - } + return Station.builder() + .stationCode(source.getIdStazione()) + .enabled(source.getEnabled()) + .version(source.getVersione()) + .password(source.getPassword()) + .connection( + Connection.builder() + .protocol(Protocol.fromValue(source.getProtocollo())) + .ip(source.getIp()) + .port(source.getPorta()) + .build()) + .service( + Service.builder() + .path(source.getServizio()) + .targetHost(source.getTargetHost()) + .targetPort(source.getTargetPort()) + .targetPath(source.getTargetPath()) + .build()) + .pofService( + Service.builder() + .path(source.getServizioPof()) + .targetHost(source.getTargetHostPof()) + .targetPort(source.getTargetPortPof()) + .targetPath(source.getTargetPathPof()) + .build()) + .mod4Service( + Service.builder() + .path(source.getServizio4Mod()) + .targetHost(source.getTargetHost()) + .targetPort(source.getTargetPort()) + .targetPath(source.getTargetPath()) + .build()) + .mod4connection( + Connection.builder() + .protocol(Protocol.fromValue(source.getProtocollo4Mod())) + .ip(source.getIp4Mod()) + .port(source.getPorta4Mod()) + .build()) + .brokerCode(source.getIntermediarioPa().getIdIntermediarioPa()) + .redirect( + Redirect.builder() + .protocol(Protocol.fromValue(source.getRedirectProtocollo())) + .ip(source.getRedirectIp()) + .port(source.getRedirectPorta()) + .path(source.getRedirectPath()) + .queryString(source.getRedirectQueryString()) + .build()) + .proxy(proxy) + .threadNumber(source.getNumThread()) + .timeouts( + Timeouts.builder() + .timeoutA(source.getTimeoutA()) + .timeoutB(source.getTimeoutB()) + .timeoutC(source.getTimeoutC()) + .build()) + .rtInstantaneousDispatch(source.getInvioRtIstantaneo()) + .primitiveVersion(source.getVersionePrimitive()) + .flagStandIn(source.getFlagStandin()) + .isPaymentOptionsEnabled(source.getIsPaymentOptionsEnabled()) + .restEndpoint(source.getRestEndpoint()) + .build(); + } }