ConnettoreBaseHTTP.java

  1. /*
  2.  * GovWay - A customizable API Gateway 
  3.  * https://govway.org
  4.  * 
  5.  * Copyright (c) 2005-2025 Link.it srl (https://link.it). 
  6.  * 
  7.  * This program is free software: you can redistribute it and/or modify
  8.  * it under the terms of the GNU General Public License version 3, as published by
  9.  * the Free Software Foundation.
  10.  *
  11.  * This program is distributed in the hope that it will be useful,
  12.  * but WITHOUT ANY WARRANTY; without even the implied warranty of
  13.  * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
  14.  * GNU General Public License for more details.
  15.  *
  16.  * You should have received a copy of the GNU General Public License
  17.  * along with this program.  If not, see <http://www.gnu.org/licenses/>.
  18.  *
  19.  */

  21. package org.openspcoop2.pdd.core.connettori;

  23. import java.io.ByteArrayOutputStream;
  24. import java.net.HttpCookie;
  25. import java.util.ArrayList;
  26. import java.util.HashMap;
  27. import java.util.List;
  28. import java.util.Map;

  30. import javax.net.ssl.SSLSocketFactory;

  32. import org.apache.commons.lang.StringUtils;
  33. import org.openspcoop2.core.config.ResponseCachingConfigurazione;
  34. import org.openspcoop2.core.config.constants.RuoloContesto;
  35. import org.openspcoop2.core.constants.CostantiConnettori;
  36. import org.openspcoop2.message.OpenSPCoop2Message;
  37. import org.openspcoop2.message.constants.ServiceBinding;
  38. import org.openspcoop2.message.rest.RestUtilities;
  39. import org.openspcoop2.pdd.config.ConfigurazionePdDManager;
  40. import org.openspcoop2.pdd.config.CostantiProprieta;
  41. import org.openspcoop2.pdd.config.ForwardProxy;
  42. import org.openspcoop2.pdd.config.ForwardProxyConfigurazione;
  43. import org.openspcoop2.pdd.config.UrlInvocazioneAPI;
  44. import org.openspcoop2.pdd.core.CostantiPdD;
  45. import org.openspcoop2.pdd.core.dynamic.DynamicMapBuilderUtils;
  46. import org.openspcoop2.pdd.core.dynamic.DynamicUtils;
  47. import org.openspcoop2.pdd.core.keystore.GestoreKeystoreCaching;
  48. import org.openspcoop2.pdd.logger.OpenSPCoop2Logger;
  49. import org.openspcoop2.pdd.mdb.ConsegnaContenutiApplicativi;
  50. import org.openspcoop2.utils.CopyStream;
  51. import org.openspcoop2.utils.UtilsException;
  52. import org.openspcoop2.utils.io.Base64Utilities;
  53. import org.openspcoop2.utils.resources.Charset;
  54. import org.openspcoop2.utils.transport.TransportUtils;
  55. import org.openspcoop2.utils.transport.http.HttpConstants;
  56. import org.openspcoop2.utils.transport.http.HttpRequestMethod;
  57. import org.openspcoop2.utils.transport.http.HttpUtilities;
  58. import org.openspcoop2.utils.transport.http.RFC2047Encoding;
  59. import org.openspcoop2.utils.transport.http.RFC2047Utilities;
  60. import org.openspcoop2.utils.transport.http.SSLConfig;

  62. /**
  63.  * ConnettoreBaseHTTP
  64.  *
  65.  *
  66.  * @author Poli Andrea (apoli@link.it)
  67.  * @author $Author$
  68.  * @version $Rev$, $Date$
  69.  */

  71. public abstract class ConnettoreBaseHTTP extends ConnettoreBaseWithResponse {
  72.     
  73.     @Override
  74.     public String getProtocollo() {
  75.         return "HTTP";
  76.     }
  77.     
  78.     /** httpMethod */
  79.     private HttpRequestMethod forceHttpMethod = null;
  80.     public void setForceHttpMethod(HttpRequestMethod forceHttpMethod) {
  81.         this.forceHttpMethod = forceHttpMethod;
  82.     }

  84.     protected HttpRequestMethod httpMethod = null;
  85.     public HttpRequestMethod getHttpMethod() {
  86.         return this.httpMethod;
  87.     }
  88.     public void setHttpMethod(OpenSPCoop2Message msg) throws ConnettoreException {
  89.         // HttpMethod
  90.         if(this.forceHttpMethod!=null) {
  91.             this.httpMethod = this.forceHttpMethod;
  92.         }
  93.         else {
  94.             if(ServiceBinding.SOAP.equals(msg.getServiceBinding())){
  95.                 this.httpMethod = HttpRequestMethod.POST;
  96.             }
  97.             else{
  98.                 if(msg.getTransportRequestContext()==null || msg.getTransportRequestContext().getRequestType()==null){
  99.                     throw new ConnettoreException("HttpRequestMethod non definito");
  100.                 }
  101.                 this.httpMethod = HttpRequestMethod.valueOf(msg.getTransportRequestContext().getRequestType().toUpperCase());
  102.                 if(this.httpMethod==null){
  103.                     throw new ConnettoreException("HttpRequestMethod sconosciuto ("+this.httpMethod+")");
  104.                 }
  105.             }
  106.         }
  107.     }
  108.     
  109.     /** SSL Configuration */
  110.     protected boolean connettoreHttps = false;
  111.     protected SSLConfig sslContextProperties;
  112.     
  113.     /** InputStream Risposta */
  114.     protected String resultHTTPMessage;

  116.     /** RFC 2047 */
  117.     boolean encodingRFC2047 = false;
  118.     Charset charsetRFC2047 = null;
  119.     RFC2047Encoding encodingAlgorithmRFC2047 = null;
  120.     boolean validazioneHeaderRFC2047 = false;
  121.     
  122.     
  123.     /** Proxy Pass Reverse */
  124.     protected boolean proxyPassReverseEnabled = false;
  125.     protected boolean proxyPassReverse_location = false;
  126.     protected boolean proxyPassReverse_setCookie_path = false;
  127.     protected boolean proxyPassReverse_setCookie_domain = false;
  128.     protected boolean proxyPassReverse_usePrefixProtocol = false;
  129.     protected List<String> proxyPassReverse_headers = null;
  130.     protected List<String> proxyPassReverse_setCookie_headers = null;
  131.     private boolean forceDisable_proxyPassReverse = false;
  132.     public void setForceDisable_proxyPassReverse(boolean forceDisable_proxyPassReverse) {
  133.         this.forceDisable_proxyPassReverse = forceDisable_proxyPassReverse;
  134.     }

  136.     /** ForwardProxy */
  137.     protected ForwardProxy forwardProxy;
  138.     protected String forwardProxy_headerName;
  139.     protected String forwardProxy_headerValue;
  140.     
  141.     @Override
  142.     protected boolean initialize(ConnettoreMsg request, boolean connectorPropertiesRequired, ResponseCachingConfigurazione responseCachingConfig){
  143.         boolean init = super.initialize(request, connectorPropertiesRequired, responseCachingConfig);
  144.         
  145.         updateForwardProxy(request.getForwardProxy());
  146.         
  147.         // Location
  148.         if(this.properties.get(CostantiConnettori.CONNETTORE_LOCATION)==null){
  149.             this.errore = "Proprieta' '"+CostantiConnettori.CONNETTORE_LOCATION+"' non fornita e richiesta da questo tipo di connettore ["+request.getTipoConnettore()+"]";
  150.             return false;
  151.         }
  152.         
  153.         if(this.idModulo!=null){
  154.             if(ConsegnaContenutiApplicativi.ID_MODULO.equals(this.idModulo)){
  155.                 this.encodingRFC2047 = this.openspcoopProperties.isEnabledEncodingRFC2047HeaderValueConsegnaContenutiApplicativi();
  156.                 this.charsetRFC2047 = this.openspcoopProperties.getCharsetEncodingRFC2047HeaderValueConsegnaContenutiApplicativi();
  157.                 this.encodingAlgorithmRFC2047 = this.openspcoopProperties.getEncodingRFC2047HeaderValueConsegnaContenutiApplicativi();
  158.                 this.validazioneHeaderRFC2047 = this.openspcoopProperties.isEnabledValidazioneRFC2047HeaderNameValueConsegnaContenutiApplicativi();
  159.             }else{
  160.                 this.encodingRFC2047 = this.openspcoopProperties.isEnabledEncodingRFC2047HeaderValueInoltroBuste();
  161.                 this.charsetRFC2047 = this.openspcoopProperties.getCharsetEncodingRFC2047HeaderValueInoltroBuste();
  162.                 this.encodingAlgorithmRFC2047 = this.openspcoopProperties.getEncodingRFC2047HeaderValueInoltroBuste();
  163.                 this.validazioneHeaderRFC2047 = this.openspcoopProperties.isEnabledValidazioneRFC2047HeaderNameValueInoltroBuste();
  164.             }
  165.             
  166.             this.encodingRFC2047 = CostantiProprieta.isConnettoriHeaderValueEncodingRFC2047RequestEnabled(this.proprietaPorta, this.encodingRFC2047);
  167.             this.charsetRFC2047 = CostantiProprieta.getConnettoriHeaderValueEncodingRFC2047RequestCharset(this.proprietaPorta, this.charsetRFC2047);
  168.             this.encodingAlgorithmRFC2047 = CostantiProprieta.getConnettoriHeaderValueEncodingRFC2047RequestType(this.proprietaPorta, this.encodingAlgorithmRFC2047);
  169.             this.validazioneHeaderRFC2047 = CostantiProprieta.isConnettoriHeaderValidationRequestEnabled(this.proprietaPorta, this.validazioneHeaderRFC2047);
  170.         }
  171.         
  172.         if(!this.forceDisable_proxyPassReverse) {
  173.             
  174.             if(this.isRest) {
  175.                 if(ConsegnaContenutiApplicativi.ID_MODULO.equals(this.idModulo)){
  176.                     this.proxyPassReverse_location = this.openspcoopProperties.isRESTServices_consegnaContenutiApplicativi_proxyPassReverse();
  177.                     this.proxyPassReverse_setCookie_path = this.openspcoopProperties.isRESTServices_consegnaContenutiApplicativi_proxyPassReverse_setCookie() && this.openspcoopProperties.isRESTServices_consegnaContenutiApplicativi_proxyPassReverse_setCookie_path();
  178.                     this.proxyPassReverse_setCookie_domain = this.openspcoopProperties.isRESTServices_consegnaContenutiApplicativi_proxyPassReverse_setCookie() && this.openspcoopProperties.isRESTServices_consegnaContenutiApplicativi_proxyPassReverse_setCookie_domain();
  179.                     this.proxyPassReverse_usePrefixProtocol = this.openspcoopProperties.isRESTServices_consegnaContenutiApplicativi_proxyPassReverse_useProtocolPrefix();
  180.                     try {
  181.                         this.proxyPassReverse_headers = this.openspcoopProperties.getRESTServices_consegnaContenutiApplicativi_proxyPassReverse_headers();
  182.                         this.proxyPassReverse_setCookie_headers = this.openspcoopProperties.getRESTServices_consegnaContenutiApplicativi_proxyPassReverse_setCookie_headers();
  183.                     }catch(Exception e) {
  184.                         this.errore = e.getMessage();
  185.                         return false;
  186.                     }
  187.                 }
  188.                 else{
  189.                     // InoltroBuste e InoltroRisposte
  190.                     this.proxyPassReverse_location = this.openspcoopProperties.isRESTServices_inoltroBuste_proxyPassReverse();
  191.                     this.proxyPassReverse_setCookie_path = this.openspcoopProperties.isRESTServices_inoltroBuste_proxyPassReverse_setCookie() && this.openspcoopProperties.isRESTServices_inoltroBuste_proxyPassReverse_setCookie_path();
  192.                     this.proxyPassReverse_setCookie_domain = this.openspcoopProperties.isRESTServices_inoltroBuste_proxyPassReverse_setCookie() && this.openspcoopProperties.isRESTServices_inoltroBuste_proxyPassReverse_setCookie_domain();
  193.                     this.proxyPassReverse_usePrefixProtocol = this.openspcoopProperties.isRESTServices_inoltroBuste_proxyPassReverse_useProtocolPrefix();
  194.                     try {
  195.                         this.proxyPassReverse_headers = this.openspcoopProperties.getRESTServices_inoltroBuste_proxyPassReverse_headers();
  196.                         this.proxyPassReverse_setCookie_headers = this.openspcoopProperties.getRESTServices_inoltroBuste_proxyPassReverse_setCookie_headers();
  197.                     }catch(Exception e) {
  198.                         this.errore = e.getMessage();
  199.                         return false;
  200.                     }
  201.                 }
  202.             }else {
  203.                 if(ConsegnaContenutiApplicativi.ID_MODULO.equals(this.idModulo)){
  204.                     this.proxyPassReverse_location = this.openspcoopProperties.isSOAPServices_consegnaContenutiApplicativi_proxyPassReverse();
  205.                     this.proxyPassReverse_setCookie_path = this.openspcoopProperties.isSOAPServices_consegnaContenutiApplicativi_proxyPassReverse_setCookie() && this.openspcoopProperties.isSOAPServices_consegnaContenutiApplicativi_proxyPassReverse_setCookie_path();
  206.                     this.proxyPassReverse_setCookie_domain = this.openspcoopProperties.isSOAPServices_consegnaContenutiApplicativi_proxyPassReverse_setCookie() && this.openspcoopProperties.isSOAPServices_consegnaContenutiApplicativi_proxyPassReverse_setCookie_domain();
  207.                     this.proxyPassReverse_usePrefixProtocol = this.openspcoopProperties.isSOAPServices_consegnaContenutiApplicativi_proxyPassReverse_useProtocolPrefix();
  208.                     try {
  209.                         this.proxyPassReverse_headers = this.openspcoopProperties.getSOAPServices_consegnaContenutiApplicativi_proxyPassReverse_headers();
  210.                         this.proxyPassReverse_setCookie_headers = this.openspcoopProperties.getSOAPServices_consegnaContenutiApplicativi_proxyPassReverse_setCookie_headers();
  211.                     }catch(Exception e) {
  212.                         this.errore = e.getMessage();
  213.                         return false;
  214.                     }
  215.                 }
  216.                 else{
  217.                     // InoltroBuste e InoltroRisposte
  218.                     this.proxyPassReverse_location = this.openspcoopProperties.isSOAPServices_inoltroBuste_proxyPassReverse();
  219.                     this.proxyPassReverse_setCookie_path = this.openspcoopProperties.isSOAPServices_inoltroBuste_proxyPassReverse_setCookie() && this.openspcoopProperties.isSOAPServices_inoltroBuste_proxyPassReverse_setCookie_path();
  220.                     this.proxyPassReverse_setCookie_domain = this.openspcoopProperties.isSOAPServices_inoltroBuste_proxyPassReverse_setCookie() && this.openspcoopProperties.isSOAPServices_inoltroBuste_proxyPassReverse_setCookie_domain();
  221.                     this.proxyPassReverse_usePrefixProtocol = this.openspcoopProperties.isSOAPServices_inoltroBuste_proxyPassReverse_useProtocolPrefix();
  222.                     try {
  223.                         this.proxyPassReverse_headers = this.openspcoopProperties.getSOAPServices_inoltroBuste_proxyPassReverse_headers();
  224.                         this.proxyPassReverse_setCookie_headers = this.openspcoopProperties.getSOAPServices_inoltroBuste_proxyPassReverse_setCookie_headers();
  225.                     }catch(Exception e) {
  226.                         this.errore = e.getMessage();
  227.                         return false;
  228.                     }
  229.                 }
  230.             }
  231.             
  232.             // check proprieta' specifiche
  233.             if(this.proprietaPorta!=null && !this.proprietaPorta.isEmpty()) {
  234.                 try {
  235.                     this.proxyPassReverse_location = CostantiProprieta.isConnettoriProxyPassReverseEnabled(this.proprietaPorta, this.proxyPassReverse_location);
  236.                     if(this.proxyPassReverse_location) {
  237.                         this.proxyPassReverse_headers = CostantiProprieta.getConnettoriProxyPassReverseHeaders(this.proprietaPorta, this.proxyPassReverse_headers);
  238.                     }
  239.                     
  240.                     this.proxyPassReverse_setCookie_path = CostantiProprieta.isConnettoriProxyPassReverseSetCookiePathEnabled(this.proprietaPorta, this.proxyPassReverse_setCookie_path);
  241.                     this.proxyPassReverse_setCookie_domain = CostantiProprieta.isConnettoriProxyPassReverseSetCookieDomainEnabled(this.proprietaPorta, this.proxyPassReverse_setCookie_domain);
  242.                     if(this.proxyPassReverse_setCookie_path || this.proxyPassReverse_setCookie_domain) {
  243.                         this.proxyPassReverse_setCookie_headers = CostantiProprieta.getConnettoriProxyPassReverseHeaders(this.proprietaPorta, this.proxyPassReverse_setCookie_headers);
  244.                     }
  245.                     
  246.                     if(this.proxyPassReverse_location || this.proxyPassReverse_setCookie_path || this.proxyPassReverse_setCookie_domain) {
  247.                         this.proxyPassReverse_usePrefixProtocol = CostantiProprieta.isConnettoriProxyPassReverseUseProtocolPrefix(this.proprietaPorta, this.proxyPassReverse_usePrefixProtocol);
  248.                     }
  249.                 }catch(Exception e) {
  250.                     this.errore = e.getMessage();
  251.                     return false;
  252.                 }
  253.             }
  254.             
  255.             if(this.proxyPassReverse_location) {
  256.                 this.proxyPassReverse_location = (this.proxyPassReverse_headers!=null && !this.proxyPassReverse_headers.isEmpty());
  257.             }
  258.             if(this.proxyPassReverse_setCookie_path) {
  259.                 this.proxyPassReverse_setCookie_path = (this.proxyPassReverse_setCookie_headers!=null && !this.proxyPassReverse_setCookie_headers.isEmpty());
  260.             }
  261.             if(this.proxyPassReverse_setCookie_domain) {
  262.                 this.proxyPassReverse_setCookie_domain = (this.proxyPassReverse_setCookie_headers!=null && !this.proxyPassReverse_setCookie_headers.isEmpty());
  263.             }

  265.             this.proxyPassReverseEnabled = this.proxyPassReverse_location || this.proxyPassReverse_setCookie_path || this.proxyPassReverse_setCookie_domain;
  266.         }
  267.         
  268.         return init;
  269.     }
  270.     
  271.     protected void setSSLContext() throws ConnettoreException{
  272.         if(this.connettoreHttps){
  273.             this.sslContextProperties = ConnettoreHTTPSProperties.readProperties(this.properties);
  274.         }
  275.         else {
  276.             String location = this.properties.get(CostantiConnettori.CONNETTORE_LOCATION);
  277.             if(!location.trim().startsWith("https")){
  278.                 if(this.debug){
  279.                     this.logger.debug("Location non richiede gestione https ["+location.trim()+"]");
  280.                 }
  281.                 return;
  282.             }
  283.             
  284.             boolean urlHttpsOverrideJvmConfiguration = ConnettoreHTTPUrlHttpsKeystoreRepository.isEnabled(this.idModulo, this.proprietaPorta);
  285.             if(!urlHttpsOverrideJvmConfiguration) {
  286.                 if(this.debug){
  287.                     this.logger.debug("Location https ["+location.trim()+"]; gestione personalizzata dei keystore disabilitata");
  288.                 }
  289.                 return;
  290.             }
  291.             
  292.             ConnettoreHTTPUrlHttpsKeystoreRepository utils = new ConnettoreHTTPUrlHttpsKeystoreRepository(this.debug, this.logger, this.idModulo);
  293.             utils.init(this.proprietaPorta, this.busta, this.dynamicMap, this.getPddContext());
  294.             this.sslContextProperties = utils.readSSLContext(this.requestInfo);
  295.         }
  296.         
  297.         this.setSecureRandomSSLContext();
  298.     }
  299.     private void setSecureRandomSSLContext() throws ConnettoreException{
  300.         if(this.sslContextProperties!=null &&
  301.                 !this.sslContextProperties.isSecureRandomSet() &&
  302.                 this.openspcoopProperties.isConnettoreHttps_useSecureRandom()
  303.                 ) {
  304.                 this.sslContextProperties.setSecureRandom(true);
  305.                 if(this.openspcoopProperties.getConnettoreHttps_secureRandomAlgo()!=null) {
  306.                     this.sslContextProperties.setSecureRandomAlgorithm(this.openspcoopProperties.getConnettoreHttps_secureRandomAlgo());
  307.                 }
  308.             }
  309.     }
  310.     
  311.     protected SSLSocketFactory buildSSLContextFactory() throws UtilsException {
  312.         // Gestione https
  313.         if(this.sslContextProperties!=null){
  314.             
  315.             StringBuilder sbError = null;
  316.             StringBuilder sbDebug = null;
  317.             try {
  318.                 sbError = new StringBuilder();
  319.                 this.sslContextProperties.setSbError(sbError);
  320.                 if(this.debug) {
  321.                     sbDebug = new StringBuilder();
  322.                     this.sslContextProperties.setSbDebug(sbDebug);
  323.                 }
  324.                 this.sslContextProperties.setLogger(this.logger.getLogger());
  325.                 Map<String,Object> dynamicMap = DynamicMapBuilderUtils.buildDynamicMap(this.busta, this.requestInfo, this.getPddContext(), 
  326.                         this.logger!=null ? this.logger.getLogger() : null);
  327.                 this.sslContextProperties.setDynamicMap(dynamicMap);
  328.                 return GestoreKeystoreCaching.getSSLSocketFactory(this.requestInfo, this.sslContextProperties).getSslSocketFactory(this.requestInfo);
  329.             }catch(Exception e) {
  330.                 if(this.logger!=null) {
  331.                     this.logger.error("Lettura SSLSocketFactory '"+this.sslContextProperties.toString()+"' dalla cache fallita: "+e.getMessage(),e);
  332.                 }
  333.                 throw new UtilsException(e.getMessage(),e);
  334.             }finally {
  335.                 if(sbError!=null && sbError.length()>0 &&
  336.                         this.logger!=null) {
  337.                     this.logger.error(sbError.toString());
  338.                 }
  339.                 if(sbDebug!=null && sbDebug.length()>0 &&
  340.                         this.logger!=null) {
  341.                     this.logger.info(sbDebug.toString(), false);
  342.                 }
  343.             }
  344.             
  345.         }
  346.         return null;
  347.     }
  348.     
  349.         
  350.     protected void updateForwardProxy(ForwardProxy forwardProxy) {
  351.         if(this.forwardProxy==null) {
  352.             this.forwardProxy = forwardProxy;
  353.         }
  354.     }
  355.     protected boolean updateLocation_forwardProxy(String location) throws ConnettoreException {
  356.         
  357.         if(this.forwardProxy!=null && this.forwardProxy.isEnabled()) {
  358.                     
  359.             ForwardProxyConfigurazione config = this.forwardProxy.getConfig();
  360.             
  361.             String base64Location = null;
  362.             if(config.getHeader()!=null) {
  363.                 this.forwardProxy_headerName = config.getHeader();
  364.                 
  365.                 if(config.isHeaderBase64()) {
  366.                     base64Location = Base64Utilities.encodeAsString(location.getBytes());
  367.                     this.forwardProxy_headerValue = base64Location;
  368.                 }
  369.                 else {
  370.                     this.forwardProxy_headerValue = location;
  371.                     if(this.encodingRFC2047){
  372.                         try {
  373.                             if(RFC2047Utilities.isAllCharactersInCharset(this.forwardProxy_headerValue, this.charsetRFC2047)==false){
  374.                                 String encoded = RFC2047Utilities.encode(new String(this.forwardProxy_headerValue), this.charsetRFC2047, this.encodingAlgorithmRFC2047);
  375.                                 //System.out.println("@@@@ CODIFICA ["+value+"] in ["+encoded+"]");
  376.                                 if(this.debug)
  377.                                     this.logger.info("RFC2047 Encoded value ["+this.forwardProxy_headerValue+"] in ["+encoded+"] (charset:"+this.charsetRFC2047+" encoding-algorithm:"+this.encodingAlgorithmRFC2047+")",false);
  378.                                 this.forwardProxy_headerValue = encoded;
  379.                             }
  380.                         }catch(Exception e) {
  381.                             throw new ConnettoreException(e.getMessage(),e);
  382.                         }
  383.                     }
  384.                 }
  385.             }
  386.             
  387.             Map<String, List<String>> queryParameters = new HashMap<>();
  388.             if(config.getQuery()!=null) {
  389.                 if(config.isQueryBase64()) {
  390.                     if(base64Location==null) {
  391.                         base64Location = Base64Utilities.encodeAsString(location.getBytes());
  392.                     }
  393.                     TransportUtils.addParameter(queryParameters,config.getQuery(), base64Location);
  394.                 }
  395.                 else {
  396.                     TransportUtils.addParameter(queryParameters,config.getQuery(), location);
  397.                 }
  398.             }
  399.             
  400.             String newUrl = this.forwardProxy.getUrl();
  401.             if(this.dynamicMap!=null) {
  402.                 try {
  403.                     newUrl = DynamicUtils.convertDynamicPropertyValue("forwardProxyUrl", newUrl, this.dynamicMap, this.getPddContext(), false);
  404.                 }catch(Exception e){
  405.                     this.logger.error("Errore durante la costruzione della url per la funzionalità di 'forwardProxy' (dynamic): "+e.getMessage(),e);
  406.                 }
  407.             }
  408.             
  409.             boolean encodeBaseLocation = true; // la base location può contenere dei parametri
  410.             this.location = TransportUtils.buildUrlWithParameters(queryParameters, newUrl, encodeBaseLocation, this.logger!=null ? this.logger.getLogger() : OpenSPCoop2Logger.getLoggerOpenSPCoopCore());
  411.             
  412.             return true;
  413.         }
  414.         
  415.         return false;
  416.         
  417.     }
  418.     
  419.     @Override
  420.     protected boolean dumpResponse(Map<String, List<String>> trasporto) throws Exception{
  421.         
  422.         if(this.isRest){
  423.             if(this.proxyPassReverseEnabled) {
  424.                 checkProxyPassReverse();
  425.             }
  426.         }
  427.         else {
  428.             /*
  429.              * Se il messaggio e' un html di errore me ne esco 
  430.              */     
  431.             if(!checkSoapHtmlResponse()) {
  432.                 return false;
  433.             }
  434.             
  435.             if(this.proxyPassReverseEnabled) {
  436.                 checkProxyPassReverse();
  437.             }
  438.         }
  439.         
  440.         return super.dumpResponse(trasporto);
  441.     }
  442.     
  443.     @Override
  444.     protected boolean doSoapResponse() throws Exception{

  446.         // gestione ordinaria via WS/SOAP
  447.         
  448.         if(this.debug)
  449.             this.logger.debug("gestione WS/SOAP in corso (check HTML) ...");
  450.         
  451.         /*
  452.          * Se il messaggio e' un html di errore me ne esco 
  453.          */     
  454.         if(!checkSoapHtmlResponse()) {
  455.             return false;
  456.         }
  457.         
  458.         if(this.proxyPassReverseEnabled) {
  459.             checkProxyPassReverse();
  460.         }
  461.         
  462.         return super.doSoapResponse();
  463.     }
  464.     
  465.     private boolean checkSoapHtmlResponse() throws Exception {
  466.         /*
  467.          * Se il messaggio e' un html di errore me ne esco 
  468.          */         
  469.         if(this.codice>=400 && 
  470.                 (
  471.                     (this.tipoRisposta!=null && this.tipoRisposta.contains(HttpConstants.CONTENT_TYPE_HTML))
  472.                     ||
  473.                     (this.tipoRisposta==null || StringUtils.isEmpty(this.tipoRisposta)) // fix per casi in cui viene ritornata una pagina html senza content-type
  474.                 )
  475.             ){
  476.             String tmpResultHTTPMessage=this.resultHTTPMessage;
  477.             if(tmpResultHTTPMessage==null) {
  478.                 // provo a tradurlo
  479.                 tmpResultHTTPMessage = HttpUtilities.getHttpReason(this.codice);
  480.             }
  481.             String tipoLetturaRisposta = "("+this.codice+") " +  tmpResultHTTPMessage;
  482.             
  483.             // Registro HTML ricevuto.
  484.             String htmlRicevuto = null;
  485.             if(this.isResponse!=null){
  486.                 
  487.                 this.emitDiagnosticResponseRead(this.isResponse);
  488.                 
  489.                 ByteArrayOutputStream bout = new ByteArrayOutputStream();
  490. //              byte [] readB = new byte[Utilities.DIMENSIONE_BUFFER];
  491. //              int readByte = 0;
  492. //              while((readByte = this.isResponse.read(readB))!= -1){
  493. //                  bout.write(readB,0,readByte);
  494. //              }
  495.                 CopyStream.copy(this.isResponse, bout);
  496.                 this.isResponse.close();
  497.                 bout.flush();
  498.                 bout.close();
  499.                 htmlRicevuto = bout.toString();
  500.             }
  501.             
  502.             if(htmlRicevuto!=null && !"".equals(htmlRicevuto))
  503.                 this.errore = tipoLetturaRisposta +"\nhttp response: "+htmlRicevuto;
  504.             else
  505.                 this.errore = tipoLetturaRisposta;
  506.             return false;
  507.         }
  508.         
  509.         return true;
  510.     }
  511.     
  512.     @Override
  513.     protected boolean doRestResponse() throws Exception{
  514.         
  515.         if(this.proxyPassReverseEnabled) {
  516.             checkProxyPassReverse();
  517.         }
  518.         
  519.         return super.doRestResponse();
  520.     }

  522.     private boolean proxyPassReverseDone = false;
  523.     private void checkProxyPassReverse() throws Exception {
  524.         if(!this.proxyPassReverseDone) {
  525.             try {
  526.                 if(this.debug)
  527.                     this.logger.debug("gestione (rest:"+this.isRest+") - proxyPassReverse:"+this.proxyPassReverseEnabled+
  528.                             " (location:"+this.proxyPassReverse_location+" setCookie-path:"+this.proxyPassReverse_setCookie_path+" setCookie-domain:"+this.proxyPassReverse_setCookie_domain+") ...");
  529.             
  530.                 if(this.proxyPassReverseEnabled) {
  531.                     
  532.                     // Raccolgo informazioni
  533.                     String baseUrl = null;
  534.                     String prefixGatewayUrl = null;
  535.                     String contesto = null;
  536.                     try {
  537.                         baseUrl = this.properties.get(CostantiConnettori.CONNETTORE_LOCATION);
  538.                         if(baseUrl==null) {
  539.                             throw new Exception("BaseURL undefined");
  540.                         }
  541.                         if(this.debug)
  542.                             this.logger.debug("Base URL: ["+baseUrl+"] ...");
  543.                          
  544.                         String interfaceName = null;
  545.                         if(this.requestMsg!=null) {
  546.                             Object porta = this.requestMsg.getContextProperty(CostantiPdD.NOME_PORTA_INVOCATA);
  547.                             if(porta!=null && porta instanceof String) {
  548.                                 interfaceName = (String) porta;
  549.                             }
  550.                             if(interfaceName==null) {
  551.                                 if(this.requestMsg.getTransportRequestContext()!=null) {
  552.                                     interfaceName = this.requestMsg.getTransportRequestContext().getInterfaceName();
  553.                                 }
  554.                             }
  555.                             if(interfaceName==null) {
  556.                                 if(this.pa!=null) {
  557.                                     interfaceName = this.pa.getNome();
  558.                                 }
  559.                                 else if(this.pd!=null) {
  560.                                     interfaceName = this.pd.getNome();
  561.                                 }
  562.                             }
  563.                         }
  564.                          
  565.                         if(this.proxyPassReverse_usePrefixProtocol) {
  566.                             UrlInvocazioneAPI urlInvocazioneApi = ConfigurazionePdDManager.getInstance().getConfigurazioneUrlInvocazione(this.getProtocolFactory(), 
  567.                                     ConsegnaContenutiApplicativi.ID_MODULO.equals(this.idModulo) ? RuoloContesto.PORTA_APPLICATIVA : RuoloContesto.PORTA_DELEGATA,
  568.                                     this.requestMsg!=null ? this.requestMsg.getServiceBinding() : null,
  569.                                     interfaceName,
  570.                                     this.requestInfo!=null ? this.requestInfo.getIdentitaPdD() : null,
  571.                                     this.getIdAccordo(),
  572.                                     this.requestInfo);       
  573.                             prefixGatewayUrl = urlInvocazioneApi.getBaseUrl();
  574.                             contesto = urlInvocazioneApi.getContext();
  575.                         }
  576.                          
  577.                     }catch(Exception e) {
  578.                         throw new Exception("Errore durante la raccolta delle informazioni necessarie alla funzione di proxy pass reverse: "+e.getMessage(),e);
  579.                     }
  580.     
  581.                     if(this.proxyPassReverse_location) {
  582.                      
  583.                         for (String header : this.proxyPassReverse_headers) {
  584.                             String redirectLocation = TransportUtils.getFirstValue(this.propertiesTrasportoRisposta, header); 
  585.                             if(redirectLocation!=null) {
  586.                                 if(this.debug)
  587.                                     this.logger.debug("Trovato Header '"+header+"':["+redirectLocation+"] ...");
  588.                                 
  589.                                 try {
  590.                                     String newRedirectLocation = RestUtilities.buildPassReverseUrl(this.requestMsg.getTransportRequestContext(), baseUrl, redirectLocation, prefixGatewayUrl, contesto);
  591.                                     if(this.debug)
  592.                                         this.logger.debug("Nuovo Header '"+header+"':["+newRedirectLocation+"] ...");
  593.                                
  594.                                     if(!redirectLocation.equals(newRedirectLocation)) {
  595.                                         TransportUtils.removeObject(this.propertiesTrasportoRisposta, header);
  596.                                         TransportUtils.addHeader(this.propertiesTrasportoRisposta,header, newRedirectLocation);
  597.                                     }
  598.                                 }catch(Exception e) {
  599.                                     throw new Exception("Errore durante l'aggiornamento dell'header '"+header+
  600.                                             "' attraverso la funzione di proxy pass reverse: "+e.getMessage(),e);
  601.                                 }
  602.                             }
  603.                         }
  604.                     }
  605.                 
  606.                     if(this.proxyPassReverse_setCookie_path || this.proxyPassReverse_setCookie_domain) {
  607.                      
  608.                         for (String header : this.proxyPassReverse_setCookie_headers) {
  609.                             List<String> cookieValues = TransportUtils.getValues(this.propertiesTrasportoRisposta, header);
  610.                             List<String> newCookieValues = null; 
  611.                             boolean modify = false;
  612.                             if(cookieValues!=null && !cookieValues.isEmpty()) {
  613.                                 
  614.                                 newCookieValues = new ArrayList<>();
  615.                                 
  616.                                 for (String cookieValue : cookieValues) {
  617.                                     if(cookieValue!=null) {
  618.                                         if(this.debug)
  619.                                             this.logger.debug("Trovato CookieHeader '"+header+"':["+cookieValue+"] ...");
  620.                                             
  621.                                         List<String> cookieNames = new ArrayList<>();
  622.                                         List<String> cookiePaths = new ArrayList<>();
  623.                                         List<String> cookieDomains = new ArrayList<>();
  624.                                         try {
  625.                                             List<HttpCookie> l = java.net.HttpCookie.parse(cookieValue);
  626.                                             for (HttpCookie httpCookie : l) {
  627.                                                 //System.out.println("cookie ["+httpCookie.getName()+"] ["+httpCookie.getPath()+"]");
  628.                                                 if(httpCookie.getPath()!=null) {
  629.                                                     cookieNames.add(httpCookie.getName());
  630.                                                     cookiePaths.add(httpCookie.getPath());
  631.                                                     cookieDomains.add(httpCookie.getDomain());
  632.                                                 }
  633.                                             }
  634.                                         }catch(Throwable e) {
  635.                                             this.logger.error("Errore durante il parsing del valore dell'header '"+header+"' (gestione cookie): "+e.getMessage(),e);
  636.                                         }
  637.                                         
  638.                                         if(!cookieNames.isEmpty()) {
  639.                                             for (int i = 0; i < cookieNames.size(); i++) {
  640.                                                 String cName = cookieNames.get(i);
  641.                                                 String cPath = cookiePaths.get(i);
  642.                                                 String cDomain = cookieDomains.get(i);
  643.                                                 
  644.                                                 String newValue = cookieValue;
  645.                                                 
  646.                                                 if(this.proxyPassReverse_setCookie_path) {
  647.                                                     try {
  648.                                                         if(cPath!=null) {
  649.                                                             String newPath = RestUtilities.buildCookiePassReversePath(this.requestMsg.getTransportRequestContext(), baseUrl, cPath, prefixGatewayUrl, contesto);
  650.                                                             if(this.debug)
  651.                                                                 this.logger.debug("Nuovo Path '"+cName+"' (header:"+header+"):["+newPath+"] ...");
  652.                                                        
  653.                                                             if(!cPath.equals(newPath)) {
  654.                                                                 newValue = newValue.replace(cPath, newPath);
  655.                                                                 /*
  656.                                                                 String newValue = newValue.replace("path="+cPath, "path="+newPath);
  657.                                                                 newValue = newValue.replace("path ="+cPath, "path ="+newPath);
  658.                                                                 newValue = newValue.replace("path= "+cPath, "path= "+newPath);
  659.                                                                 newValue = newValue.replace("path = "+cPath, "path = "+newPath);
  660.                                                                 
  661.                                                                 newValue = newValue.replace("Path="+cPath, "Path="+newPath);
  662.                                                                 newValue = newValue.replace("Path ="+cPath, "Path ="+newPath);
  663.                                                                 newValue = newValue.replace("Path= "+cPath, "Path= "+newPath);
  664.                                                                 newValue = newValue.replace("Path = "+cPath, "Path = "+newPath);
  665.                                                                 
  666.                                                                 newValue = newValue.replace("PATH="+cPath, "PATH="+newPath);
  667.                                                                 newValue = newValue.replace("PATH ="+cPath, "PATH ="+newPath);
  668.                                                                 newValue = newValue.replace("PATH= "+cPath, "PATH= "+newPath);
  669.                                                                 newValue = newValue.replace("PATH = "+cPath, "PATH = "+newPath);
  670.                                                                 
  671.                                                                 newValue + newValue.replace("path=\""+cPath, "path=\""+newPath);
  672.                                                                 newValue = newValue.replace("path =\""+cPath, "path =\""+newPath);
  673.                                                                 newValue = newValue.replace("path= \""+cPath, "path= \""+newPath);
  674.                                                                 newValue = newValue.replace("path = \""+cPath, "path = \""+newPath);
  675.                                                                 
  676.                                                                 newValue = newValue.replace("Path=\""+cPath, "Path=\""+newPath);
  677.                                                                 newValue = newValue.replace("Path =\""+cPath, "Path =\""+newPath);
  678.                                                                 newValue = newValue.replace("Path= \""+cPath, "Path= \""+newPath);
  679.                                                                 newValue = newValue.replace("Path = \""+cPath, "Path = \""+newPath);
  680.                                                                 
  681.                                                                 newValue = newValue.replace("PATH=\""+cPath, "PATH=\""+newPath);
  682.                                                                 newValue = newValue.replace("PATH =\""+cPath, "PATH =\""+newPath);
  683.                                                                 newValue = newValue.replace("PATH= \""+cPath, "PATH= \""+newPath);
  684.                                                                 newValue = newValue.replace("PATH = \""+cPath, "PATH = \""+newPath);*/
  685.                                                                 
  686.                                                                 modify=true;
  687.                                                             }
  688.                                                         }
  689.                                                     }catch(Exception e) {
  690.                                                         throw new Exception("Errore durante l'aggiornamento del cookie '"+cName+
  691.                                                                 "' (header:"+header+") attraverso la funzione di proxy pass reverse: "+e.getMessage(),e);
  692.                                                     }   
  693.                                                 }
  694.                                                 
  695.                                                 if(this.proxyPassReverse_setCookie_domain) {
  696.                                                     try {
  697.                                                         if(cDomain!=null) {
  698.                                                             String newDomain = RestUtilities.buildCookiePassReverseDomain(this.requestMsg.getTransportRequestContext(), baseUrl, cDomain, prefixGatewayUrl);
  699.                                                             if(this.debug)
  700.                                                                 this.logger.debug("Nuovo Domain '"+cDomain+"' (header:"+header+"):["+newDomain+"] ...");
  701.                                                        
  702.                                                             if(!cDomain.equals(newDomain)) {
  703.                                                                 newValue = newValue.replace(cDomain, newDomain);
  704.                                                                 /*
  705.                                                                 String newValue = newValue.replace("domain="+cDomain, "domain="+newDomain);
  706.                                                                 newValue = newValue.replace("domain ="+cDomain, "domain ="+newDomain);
  707.                                                                 newValue = newValue.replace("domain= "+cDomain, "domain= "+newDomain);
  708.                                                                 newValue = newValue.replace("domain = "+cDomain, "domain = "+newDomain);
  709.                                                                 
  710.                                                                 newValue = newValue.replace("Domain="+cDomain, "Domain="+newDomain);
  711.                                                                 newValue = newValue.replace("Domain ="+cDomain, "Domain ="+newDomain);
  712.                                                                 newValue = newValue.replace("Domain= "+cDomain, "Domain= "+newDomain);
  713.                                                                 newValue = newValue.replace("Domain = "+cDomain, "Domain = "+newDomain);
  714.                                                                 
  715.                                                                 newValue = newValue.replace("DOMAIN="+cDomain, "DOMAIN="+newDomain);
  716.                                                                 newValue = newValue.replace("DOMAIN ="+cDomain, "DOMAIN ="+newDomain);
  717.                                                                 newValue = newValue.replace("DOMAIN= "+cDomain, "DOMAIN= "+newDomain);
  718.                                                                 newValue = newValue.replace("DOMAIN = "+cDomain, "DOMAIN = "+newDomain);
  719.                                                                 
  720.                                                                 newValue + newValue.replace("domain=\""+cDomain, "domain=\""+newDomain);
  721.                                                                 newValue = newValue.replace("domain =\""+cDomain, "domain =\""+newDomain);
  722.                                                                 newValue = newValue.replace("domain= \""+cDomain, "domain= \""+newDomain);
  723.                                                                 newValue = newValue.replace("domain = \""+cDomain, "domain = \""+newDomain);
  724.                                                                 
  725.                                                                 newValue = newValue.replace("Domain=\""+cDomain, "Domain=\""+newDomain);
  726.                                                                 newValue = newValue.replace("Domain =\""+cDomain, "Domain =\""+newDomain);
  727.                                                                 newValue = newValue.replace("Domain= \""+cDomain, "Domain= \""+newDomain);
  728.                                                                 newValue = newValue.replace("Domain = \""+cDomain, "Domain = \""+newDomain);
  729.                                                                 
  730.                                                                 newValue = newValue.replace("DOMAIN=\""+cDomain, "DOMAIN=\""+newDomain);
  731.                                                                 newValue = newValue.replace("DOMAIN =\""+cDomain, "DOMAIN =\""+newDomain);
  732.                                                                 newValue = newValue.replace("DOMAIN= \""+cDomain, "DOMAIN= \""+newDomain);
  733.                                                                 newValue = newValue.replace("DOMAIN = \""+cDomain, "DOMAIN = \""+newDomain);*/
  734.                                                                 
  735.                                                                 modify=true;
  736.                                                             }
  737.                                                         }
  738.                                                     }catch(Exception e) {
  739.                                                         throw new Exception("Errore durante l'aggiornamento del cookie '"+cName+
  740.                                                                 "' (header:"+header+") attraverso la funzione di proxy pass reverse: "+e.getMessage(),e);
  741.                                                     }
  742.                                                 }
  743.                                                 
  744.                                                 newCookieValues.add(newValue);
  745.                                             
  746.                                             } // end for (int i = 0; i < cookieNames.size(); i++) {
  747.                                         } // end !cookieNames.isEmpty()
  748.                                     } // end cookieValue!=null
  749.                                 } // end for (String cookieValue : cookieValues) {
  750.                             } //end if(cookieValues!=null && !cookieValues.isEmpty()) {
  751.                             
  752.                             if(modify) {
  753.                                 TransportUtils.removeObject(this.propertiesTrasportoRisposta, header);
  754.                                 this.propertiesTrasportoRisposta.put(header, newCookieValues);
  755.                             }
  756.                         }
  757.                     }
  758.                  
  759.                 }
  760.                 
  761.             }finally {
  762.                 this.proxyPassReverseDone = true;
  763.             }
  764.          }
  765.     }
  766. }
Created with JaCoCo 0.8.8.202204050719