ConnettoreUtils.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.util.HashMap;
  24. import java.util.Iterator;
  25. import java.util.List;
  26. import java.util.Map;

  28. import org.apache.commons.lang.StringUtils;
  29. import org.openspcoop2.core.config.GenericProperties;
  30. import org.openspcoop2.core.config.InvocazioneCredenziali;
  31. import org.openspcoop2.core.config.InvocazioneServizio;
  32. import org.openspcoop2.core.config.ServizioApplicativo;
  33. import org.openspcoop2.core.config.constants.CostantiConfigurazione;
  34. import org.openspcoop2.core.config.constants.StatoFunzionalita;
  35. import org.openspcoop2.core.constants.CostantiConnettori;
  36. import org.openspcoop2.core.constants.CostantiLabel;
  37. import org.openspcoop2.core.constants.TipiConnettore;
  38. import org.openspcoop2.message.OpenSPCoop2Message;
  39. import org.openspcoop2.message.OpenSPCoop2MessageProperties;
  40. import org.openspcoop2.message.constants.ServiceBinding;
  41. import org.openspcoop2.message.rest.RestUtilities;
  42. import org.openspcoop2.pdd.config.ForwardProxy;
  43. import org.openspcoop2.pdd.config.OpenSPCoop2Properties;
  44. import org.openspcoop2.pdd.core.CostantiPdD;
  45. import org.openspcoop2.pdd.core.PdDContext;
  46. import org.openspcoop2.pdd.core.dynamic.DynamicUtils;
  47. import org.openspcoop2.pdd.core.token.PolicyNegoziazioneToken;
  48. import org.openspcoop2.pdd.core.token.TokenUtilities;
  49. import org.openspcoop2.pdd.logger.OpenSPCoop2Logger;
  50. import org.openspcoop2.pdd.mdb.ConsegnaContenutiApplicativi;
  51. import org.openspcoop2.protocol.sdk.Busta;
  52. import org.openspcoop2.protocol.sdk.Context;
  53. import org.openspcoop2.protocol.sdk.IProtocolFactory;
  54. import org.openspcoop2.protocol.sdk.ProtocolException;
  55. import org.openspcoop2.protocol.utils.PorteNamingUtils;
  56. import org.openspcoop2.utils.Utilities;
  57. import org.openspcoop2.utils.certificate.byok.BYOKManager;
  58. import org.openspcoop2.utils.certificate.hsm.HSMUtils;
  59. import org.openspcoop2.utils.certificate.ocsp.OCSPManager;
  60. import org.openspcoop2.utils.transport.TransportUtils;
  61. import org.openspcoop2.utils.transport.http.HttpRequestMethod;
  62. import org.slf4j.Logger;


  65. /**
  66.  * ConnettoreUtils
  67.  *
  68.  *
  69.  * @author Poli Andrea (apoli@link.it)
  70.  * @author $Author$
  71.  * @version $Rev$, $Date$
  72.  */
  73. public class ConnettoreUtils {

  75.     public static String formatLocation(HttpRequestMethod httpMethod, String location){
  76.         if(httpMethod!=null)
  77.             return location+" http-method:"+httpMethod;
  78.         else
  79.             return location;
  80.     }
  81.     
  82.     public static String getAndReplaceLocationWithBustaValues(IConnettore connector, ConnettoreMsg connettoreMsg,Busta busta,PdDContext pddContext,IProtocolFactory<?> protocolFactory,Logger log) throws ConnettoreException{
  83.         
  84.         boolean dynamicLocation = false;
  85.         
  86.         String location = null;
  87.         if(TipiConnettore.NULL.getNome().equals(connettoreMsg.getTipoConnettore())){
  88.             location = ConnettoreNULL.LOCATION;
  89.         }
  90.         else if(TipiConnettore.NULLECHO.getNome().equals(connettoreMsg.getTipoConnettore())){
  91.             location = ConnettoreNULLEcho.LOCATION;
  92.         }
  93.         else if(TipiConnettore.STATUS.getNome().equals(connettoreMsg.getTipoConnettore())){
  94.             location = ConnettoreStatus.LOCATION;
  95.         }
  96.         else if(ConnettoreStresstest.ENDPOINT_TYPE.equals(connettoreMsg.getTipoConnettore())){
  97.             location = ConnettoreStresstest.LOCATION;
  98.         }
  99.         else if(TipiConnettore.FILE.getNome().equals(connettoreMsg.getTipoConnettore())){
  100.             try{
  101.                 location = ((ConnettoreFILE)connector).buildLocation(connettoreMsg);
  102.                 //dynamicLocation = true; la dinamicita viene gia gestita nel metodo buildLocation
  103.             }catch(Exception e){
  104.                 log.error("Errore durante la costruzione della location: "+e.getMessage(),e);
  105.                 location = "N.D.";
  106.             }
  107.         }
  108.         else if(ConnettoreRicezioneBusteDirectVM.TIPO.equals(connettoreMsg.getTipoConnettore())){
  109.             try{
  110.                 ((ConnettoreRicezioneBusteDirectVM)connector).validate(connettoreMsg);
  111.                 ((ConnettoreRicezioneBusteDirectVM)connector).buildLocation(connettoreMsg.getConnectorProperties(),false);
  112.                 location = connector.getLocation();
  113.                 dynamicLocation = true;
  114.             }catch(Exception e){
  115.                 log.error("Errore durante la costruzione della location: "+e.getMessage(),e);
  116.                 location = "N.D.";
  117.             }
  118.         }
  119.         else if(ConnettoreRicezioneContenutiApplicativiDirectVM.TIPO.equals(connettoreMsg.getTipoConnettore())){
  120.             try{
  121.                 ((ConnettoreRicezioneContenutiApplicativiDirectVM)connector).validate(connettoreMsg);
  122.                 ((ConnettoreRicezioneContenutiApplicativiDirectVM)connector).buildLocation(connettoreMsg.getConnectorProperties(),false);
  123.                 location = connector.getLocation();
  124.                 dynamicLocation = true;
  125.             }catch(Exception e){
  126.                 log.error("Errore durante la costruzione della location: "+e.getMessage(),e);
  127.                 location = "N.D.";
  128.             }
  129.         }
  130.         else if(ConnettoreRicezioneContenutiApplicativiHTTPtoSOAPDirectVM.TIPO.equals(connettoreMsg.getTipoConnettore())){
  131.             try{
  132.                 ((ConnettoreRicezioneContenutiApplicativiHTTPtoSOAPDirectVM)connector).validate(connettoreMsg);
  133.                 ((ConnettoreRicezioneContenutiApplicativiHTTPtoSOAPDirectVM)connector).buildLocation(connettoreMsg.getConnectorProperties(),false);
  134.                 location = connector.getLocation();
  135.                 dynamicLocation = true;
  136.             }catch(Exception e){
  137.                 log.error("Errore durante la costruzione della location: "+e.getMessage(),e);
  138.                 location = "N.D.";
  139.             }
  140.         }
  141.         else{
  142.             if(connettoreMsg.getConnectorProperties().get(CostantiConnettori.CONNETTORE_LOCATION)!=null){
  143.                 location = connettoreMsg.getConnectorProperties().get(CostantiConnettori.CONNETTORE_LOCATION);
  144.                 dynamicLocation = true; // http, jms, ...
  145.             }
  146.         }
  147.         
  148.         if(location !=null && (location.equals("")==false) ){
  149.             
  150.             // Keyword old
  151.             location = location.replace(CostantiConnettori.CONNETTORE_JMS_LOCATION_REPLACE_TOKEN_TIPO_SERVIZIO,busta.getTipoServizio());
  152.             location = location.replace(CostantiConnettori.CONNETTORE_JMS_LOCATION_REPLACE_TOKEN_NOME_SERVIZIO,busta.getServizio());
  153.             if(busta.getAzione()!=null){
  154.                 location = location.replace(CostantiConnettori.CONNETTORE_JMS_LOCATION_REPLACE_TOKEN_AZIONE,busta.getAzione());
  155.             }
  156.             
  157.             // Dynamic
  158.             // Costruisco Mappa per dynamic name
  159.             if(dynamicLocation) {
  160.                 try {
  161.                     Map<String, Object> dynamicMap = ((ConnettoreBase)connector).buildDynamicMap(connettoreMsg);
  162.                     location = DynamicUtils.convertDynamicPropertyValue(CostantiConnettori.CONNETTORE_LOCATION, location, dynamicMap, pddContext, false);
  163.                 }catch(Exception e){
  164.                     log.error("Errore durante la costruzione della location (dynamic): "+e.getMessage(),e);
  165.                 }
  166.             }
  167.             
  168.             connettoreMsg.getConnectorProperties().put(CostantiConnettori.CONNETTORE_LOCATION,location);
  169.         }
  170.         
  171.         return location;
  172.     }
  173.     
  174.     public static String buildLocationWithURLBasedParameter(Logger log, OpenSPCoop2Message msg, String tipoConnettore, Map<String, List<String>> propertiesURLBased, String locationParam,
  175.             IProtocolFactory<?> protocolFactory, String idModulo) throws ConnettoreException{
  176.         
  177.         if(TipiConnettore.HTTP.toString().equals(tipoConnettore) || 
  178.                 TipiConnettore.HTTPS.toString().equals(tipoConnettore) ||
  179.                 ConnettoreHTTPCORE.ENDPOINT_TYPE.equals(tipoConnettore) ||
  180.                 ConnettoreSAAJ.ENDPOINT_TYPE.equals(tipoConnettore)  ||
  181.                 ConnettoreStresstest.ENDPOINT_TYPE.equals(tipoConnettore)){
  182.     
  183.             try{
  184.             
  185.                 OpenSPCoop2MessageProperties forwardParameter = null;
  186.                 if(ServiceBinding.REST.equals(msg.getServiceBinding())) {
  187.                     forwardParameter = msg.getForwardUrlProperties(OpenSPCoop2Properties.getInstance().getRESTServicesUrlParametersForwardConfig());
  188.                 }
  189.                 else {
  190.                     forwardParameter = msg.getForwardUrlProperties(OpenSPCoop2Properties.getInstance().getSOAPServicesUrlParametersForwardConfig());
  191.                 }
  192.                 
  193.                 Map<String, List<String>>  p = propertiesURLBased;
  194.                 if(forwardParameter!=null && forwardParameter.size()>0){
  195.                     if(p==null){
  196.                         p = new HashMap<> ();
  197.                     }
  198.                     Iterator<String> keys = forwardParameter.getKeys();
  199.                     while (keys.hasNext()) {
  200.                         String key = (String) keys.next();
  201.                         List<String> values = forwardParameter.getPropertyValues(key);
  202.                         if(values!=null && !values.isEmpty()){
  203.                             if(p.containsKey(key)){
  204.                                 p.remove(key);
  205.                             }
  206.                             p.put(key, values);
  207.                         }
  208.                     }
  209.                 }
  210.                 
  211.                 String location = locationParam;
  212.                 if(ServiceBinding.REST.equals(msg.getServiceBinding())){
  213.                     
  214.                     String normalizedInterfaceName = normalizeInterfaceName(msg, idModulo, protocolFactory);
  215.                     
  216.                     return RestUtilities.buildUrl(log, location, p, msg.getTransportRequestContext(),
  217.                             normalizedInterfaceName);
  218.                 }
  219.                 else{
  220.                     boolean encodeBaseLocation = true; // la base location può contenere dei parametri
  221.                     return TransportUtils.buildUrlWithParameters(p, location, encodeBaseLocation, OpenSPCoop2Logger.getLoggerOpenSPCoopCore());
  222.                 }
  223.                 
  224.             }catch(Exception e){
  225.                 throw new ConnettoreException(e.getMessage(),e);
  226.             }
  227.         }
  228.         return locationParam;
  229.     }

  231.     public static String normalizeInterfaceName(OpenSPCoop2Message msg, String idModulo, IProtocolFactory<?> protocolFactory) throws ProtocolException {
  232.         Object nomePortaInvocataObject = msg.getContextProperty(CostantiPdD.NOME_PORTA_INVOCATA);
  233.         String nomePortaInvocata = null;
  234.         if(nomePortaInvocataObject!=null && nomePortaInvocataObject instanceof String) {
  235.             nomePortaInvocata = (String) nomePortaInvocataObject;
  236.         }
  237.         else if(msg.getTransportRequestContext()!=null && msg.getTransportRequestContext().getInterfaceName()!=null) {
  238.             nomePortaInvocata = msg.getTransportRequestContext().getInterfaceName();
  239.         }
  240.         
  241.         String normalizedInterfaceName = null;
  242.         if(nomePortaInvocata!=null) {
  243.             PorteNamingUtils namingUtils = new PorteNamingUtils(protocolFactory);
  244.             if(ConsegnaContenutiApplicativi.ID_MODULO.equals(idModulo)){
  245.                 normalizedInterfaceName = namingUtils.normalizePA(nomePortaInvocata);
  246.             }
  247.             else {
  248.                 normalizedInterfaceName = namingUtils.normalizePD(nomePortaInvocata);
  249.             }
  250.         }
  251.         
  252.         return normalizedInterfaceName;
  253.     }
  254.     
  255.     public static String limitLocation255Character(String location){
  256.         return TransportUtils.limitLocation255Character(location);
  257.     }
  258.     
  259.     public static String addProxyInfoToLocationForHTTPConnector(String tipoConnettore, Map<String, String> properties, String location){
  260.         if(TipiConnettore.HTTP.toString().equals(tipoConnettore) || 
  261.                 TipiConnettore.HTTPS.toString().equals(tipoConnettore)){
  262.             if(properties.get(CostantiConnettori.CONNETTORE_HTTP_PROXY_TYPE)!=null){
  263.                 String proxyHostname = properties.get(CostantiConnettori.CONNETTORE_HTTP_PROXY_HOSTNAME);
  264.                 String proxyPort = properties.get(CostantiConnettori.CONNETTORE_HTTP_PROXY_PORT);
  265.                 return location+" [proxy: "+proxyHostname+":"+proxyPort+"]";
  266.             }
  267.         }
  268.         return location;
  269.     }
  270.     
  271.     public static String addGovWayProxyInfoToLocationForHTTPConnector(ForwardProxy forwardProxy, IConnettore connectorSender, String location) throws ConnettoreException {
  272.         if(forwardProxy!=null && connectorSender instanceof ConnettoreBaseHTTP) {
  273.             ConnettoreBaseHTTP http = (ConnettoreBaseHTTP) connectorSender;
  274.             http.updateForwardProxy(forwardProxy);
  275.             if(http.updateLocation_forwardProxy(location)) {
  276.                 return http.getLocation();
  277.             }
  278.         }
  279.         return location;
  280.     }
  281.     

  283.     public static void printDatiConnettore(org.openspcoop2.core.registry.Connettore connettore, String labelTipoConnettore, String labelNomeConnettore,
  284.             boolean connettoreStatic,
  285.             StringBuilder sb,
  286.             String separator, String newLine,
  287.             boolean printIntestazione) {
  288.         printDatiConnettore(connettore.mappingIntoConnettoreConfigurazione(), labelTipoConnettore, labelNomeConnettore,
  289.                 null, connettoreStatic,
  290.                 sb,
  291.                 separator, newLine,
  292.                 printIntestazione);
  293.     }
  294.     public static void printDatiConnettore(org.openspcoop2.core.config.Connettore connettore, String labelTipoConnettore, String labelNomeConnettore,
  295.             ServizioApplicativo sa, 
  296.             boolean connettoreStatic,
  297.             StringBuilder sb,
  298.             String separator, String newLine,
  299.             boolean printIntestazione) {

  301.         if(connettoreStatic) {
  302.             return; // non visualizzo nulla
  303.         }
  304.         
  305.         Boolean integrationManager = null;
  306.         InvocazioneCredenziali invCredenziali = null;
  307.         if(sa!=null) {
  308.             InvocazioneServizio is = sa.getInvocazioneServizio();
  309.             integrationManager = is.getGetMessage()!=null && StatoFunzionalita.ABILITATO.equals(is.getGetMessage());
  310.             invCredenziali = is.getCredenziali();
  311.         }
  312.         
  313.         TipiConnettore tipo = TipiConnettore.toEnumFromName(connettore.getTipo());
  314.         if(tipo==null) {
  315.             tipo = TipiConnettore.CUSTOM;
  316.         }
  317.         
  318.         if(printIntestazione) {
  319.             sb.append(newLine);
  320.             String label = labelNomeConnettore!=null ? " "+labelNomeConnettore : "";
  321.             sb.append("- "+CostantiLabel.LABEL_CONNETTORE+label+" -");
  322.         }
  323.         
  324.         String tipoConnettore = labelTipoConnettore;
  325.         if(TipiConnettore.DISABILITATO.equals(tipo)) {
  326.             if(integrationManager!=null && integrationManager) {
  327.                 tipoConnettore = "MessageBox";
  328.             }
  329.         }
  330.         else {
  331.             if(integrationManager!=null && integrationManager) {
  332.                 tipoConnettore = tipoConnettore + " + MessageBox";
  333.             }
  334.         }
  335.         sb.append(newLine);
  336.         sb.append(CostantiLabel.LABEL_TIPO_CONNETTORE);
  337.         sb.append(separator);
  338.         sb.append(tipoConnettore);
  339.         
  340.         String labelEndpoint = CostantiLabel.LABEL_CONNETTORE_ENDPOINT;
  341.         String endpoint = null;
  342.         if(TipiConnettore.HTTP.getNome().equals(connettore.getTipo()) || TipiConnettore.HTTPS.getNome().equals(connettore.getTipo())){
  343.             endpoint = getProperty(CostantiConnettori.CONNETTORE_LOCATION, connettore.getPropertyList());
  344.         }
  345.         else if(TipiConnettore.JMS.getNome().equals(connettore.getTipo())){
  346.             String tipoCoda = getProperty(CostantiConnettori.CONNETTORE_JMS_TIPO, connettore.getPropertyList());
  347.             labelEndpoint = CostantiLabel.LABEL_CONNETTORE_JMS_NOME_CODA+" "+tipoCoda;
  348.             endpoint = getProperty(CostantiConnettori.CONNETTORE_LOCATION, connettore.getPropertyList());
  349.         }
  350.         else if(TipiConnettore.FILE.getNome().equals(connettore.getTipo())){
  351.             labelEndpoint = CostantiLabel.LABEL_OUTPUT_FILE;
  352.             endpoint = getProperty(CostantiConnettori.CONNETTORE_FILE_REQUEST_OUTPUT_FILE, connettore.getPropertyList());
  353.         }
  354.         else if(TipiConnettore.NULL.getNome().equals(connettore.getTipo())){
  355.             //endpoint = org.openspcoop2.pdd.core.connettori.ConnettoreNULL.LOCATION;
  356.         }
  357.         else if(TipiConnettore.NULLECHO.getNome().equals(connettore.getTipo())){
  358.             //endpoint = org.openspcoop2.pdd.core.connettori.ConnettoreNULLEcho.LOCATION;
  359.         }
  360.         else if(TipiConnettore.STATUS.getNome().equals(connettore.getTipo())){
  361.             //endpoint = org.openspcoop2.pdd.core.connettori.ConnettoreStatus.LOCATION;
  362.         }
  363.         else {
  364.             String endpointV = getProperty(CostantiConnettori.CONNETTORE_LOCATION, connettore.getPropertyList());
  365.             if(StringUtils.isNotEmpty(endpointV)) {
  366.                 endpoint = endpointV;
  367.             }
  368.         }
  369.         if(endpoint!=null) {
  370.             sb.append(newLine);
  371.             sb.append(labelEndpoint);
  372.             sb.append(separator);
  373.             sb.append(endpoint);
  374.         }
  375.         
  376.         if(sa!=null && CostantiConfigurazione.SERVER.equals(sa.getTipo())) {
  377.             sb.append(newLine);
  378.             sb.append(CostantiLabel.LABEL_SERVER);
  379.             sb.append(separator);
  380.             sb.append(sa.getNome());
  381.         }
  382.         
  383.         String connectionTimeout = getProperty(CostantiConnettori.CONNETTORE_CONNECTION_TIMEOUT, connettore.getPropertyList());
  384.         if(connectionTimeout!=null) {
  385.             try {
  386.                 long l = Long.valueOf(connectionTimeout);
  387.                 if(l>0) {
  388.                     sb.append(newLine);
  389.                     sb.append(CostantiLabel.LABEL_CONNETTORE_TEMPI_RISPOSTA_CONNECTION_TIMEOUT);
  390.                     sb.append(separator);
  391.                     sb.append(Utilities.convertSystemTimeIntoStringMillisecondi(l, true, false, " "," ",""));
  392.                 }
  393.             }catch(Throwable t) {}
  394.         }
  395.         String readConnectionTimeout = getProperty(CostantiConnettori.CONNETTORE_READ_CONNECTION_TIMEOUT, connettore.getPropertyList());
  396.         if(readConnectionTimeout!=null) {
  397.             try {
  398.                 long l = Long.valueOf(readConnectionTimeout);
  399.                 if(l>0) {
  400.                     sb.append(newLine);
  401.                     sb.append(CostantiLabel.LABEL_CONNETTORE_TEMPI_RISPOSTA_READ_TIMEOUT);
  402.                     sb.append(separator);
  403.                     sb.append(Utilities.convertSystemTimeIntoStringMillisecondi(l, true, false, " "," ",""));
  404.                 }
  405.             }catch(Throwable t) {}
  406.         }
  407.         
  408.         if(TipiConnettore.HTTP.getNome().equals(connettore.getTipo()) || TipiConnettore.HTTPS.getNome().equals(connettore.getTipo())){
  409.             
  410.             String token = getProperty(CostantiConnettori.CONNETTORE_TOKEN_POLICY, connettore.getPropertyList());
  411.             if(token!=null) {
  412.                 sb.append(newLine);
  413.                 sb.append(CostantiLabel.LABEL_VERIFICA_CONNETTORE_DETAILS_TOKEN).append(" - ").append(CostantiLabel.LABEL_CONNETTORE_TOKEN_POLICY);
  414.                 sb.append(separator);
  415.                 sb.append(token);
  416.             }
  417.             
  418.             String username = null;
  419.             if(invCredenziali!=null){
  420.                 username = invCredenziali.getUser();
  421.             }
  422.             else{
  423.                 username = getProperty(CostantiConnettori.CONNETTORE_USERNAME, connettore.getPropertyList());
  424.             }
  425.             if(username!=null) {
  426.                 sb.append(newLine);
  427.                 sb.append(CostantiLabel.LABEL_VERIFICA_CONNETTORE_DETAILS_HTTP).append(" - ").append(CostantiLabel.LABEL_CREDENZIALI_AUTENTICAZIONE_USERNAME);
  428.                 sb.append(separator);
  429.                 sb.append(username);
  430.             }
  431.             
  432.             String bearerToken = getProperty(CostantiConnettori.CONNETTORE_BEARER_TOKEN, connettore.getPropertyList());
  433.             if(bearerToken!=null) {
  434.                 sb.append(newLine);
  435.                 sb.append(CostantiLabel.LABEL_VERIFICA_CONNETTORE_DETAILS_BEARER).append(" ").append(CostantiLabel.LABEL_CONNETTORE_BEARER_TOKEN);
  436.                 sb.append(separator);
  437.                 sb.append(bearerToken);
  438.             }
  439.             
  440.             String apiKey = getProperty(CostantiConnettori.CONNETTORE_APIKEY, connettore.getPropertyList());
  441.             if(apiKey!=null && StringUtils.isNotEmpty(apiKey)){
  442.                 
  443.                 String apiKeyHeader = getProperty(CostantiConnettori.CONNETTORE_APIKEY_HEADER, connettore.getPropertyList());
  444.                 if(apiKeyHeader==null || StringUtils.isEmpty(apiKeyHeader)) {
  445.                     apiKeyHeader = CostantiConnettori.DEFAULT_HEADER_API_KEY;
  446.                 }
  447.                 
  448.                 sb.append(newLine);
  449.                 sb.append(CostantiLabel.LABEL_VERIFICA_CONNETTORE_DETAILS_API_KEY).append(" '").append(apiKeyHeader).append("'");
  450.                 /**sb.append(separator);
  451.                 sb.append(apiKey); Informazione sensibile*/
  452.                 
  453.                 String appId = getProperty(CostantiConnettori.CONNETTORE_APIKEY_APPID, connettore.getPropertyList());
  454.                 if(appId!=null && StringUtils.isNotEmpty(appId)){
  455.                     
  456.                     String appIdHeader = getProperty(CostantiConnettori.CONNETTORE_APIKEY_APPID_HEADER, connettore.getPropertyList());
  457.                     if(appIdHeader==null || StringUtils.isEmpty(appIdHeader)) {
  458.                         appIdHeader = CostantiConnettori.DEFAULT_HEADER_APP_ID;
  459.                     }
  460.                     
  461.                     sb.append(newLine);
  462.                     sb.append(CostantiLabel.LABEL_VERIFICA_CONNETTORE_DETAILS_API_KEY_APP_ID).append(" '").append(appIdHeader).append("'");
  463.                     sb.append(separator);
  464.                     sb.append(appId);
  465.                     
  466.                 }
  467.             }
  468.             
  469.         }
  470.         
  471.         if(TipiConnettore.HTTPS.getNome().equals(connettore.getTipo())){
  472.             
  473.             boolean trustAllCerts = false;
  474.             String trustAllCertsV = getProperty(CostantiConnettori.CONNETTORE_HTTPS_TRUST_ALL_CERTS, connettore.getPropertyList());
  475.             if("true".equalsIgnoreCase(trustAllCertsV)) {
  476.                 trustAllCerts = true;
  477.             }
  478.             
  479.             String trustLocation = getProperty(CostantiConnettori.CONNETTORE_HTTPS_TRUST_STORE_LOCATION, connettore.getPropertyList());
  480.             
  481.             if(trustAllCerts || trustLocation!=null) {
  482.                 
  483.                 String sslType = getProperty(CostantiConnettori.CONNETTORE_HTTPS_SSL_TYPE, connettore.getPropertyList());
  484.                 if(sslType!=null) {
  485.                     sb.append(newLine);
  486.                     sb.append(CostantiLabel.LABEL_VERIFICA_CONNETTORE_DETAILS_HTTPS);
  487.                     sb.append(separator);
  488.                     sb.append(sslType);
  489.                 }
  490.                 
  491.                 String hostnameVerifier = getProperty(CostantiConnettori.CONNETTORE_HTTPS_HOSTNAME_VERIFIER, connettore.getPropertyList());
  492.                 if(hostnameVerifier!=null) {
  493.                     sb.append(newLine);
  494.                     sb.append(CostantiLabel.LABEL_CONNETTORE_HTTPS_HOST_VERIFY);
  495.                     sb.append(separator);
  496.                     sb.append(hostnameVerifier);
  497.                 }
  498.                 
  499.                 sb.append(newLine);
  500.                 sb.append(CostantiLabel.LABEL_VERIFICA_CONNETTORE_DETAILS_HTTPS_TRUSTSTORE);
  501.                 sb.append(separator);
  502.                 if(trustAllCerts) {
  503.                     sb.append(CostantiLabel.LABEL_VERIFICA_CONNETTORE_DETAILS_HTTPS_TRUST_ALL_CERTS);
  504.                 }
  505.                 else {
  506.                     String trustType = getProperty(CostantiConnettori.CONNETTORE_HTTPS_TRUST_STORE_TYPE, connettore.getPropertyList());
  507.                     boolean hsm = HSMUtils.isKeystoreHSM(trustType);
  508.                     if(hsm) {
  509.                         trustLocation = CostantiLabel.CONNETTORE_HSM;
  510.                     }
  511.                     sb.append("(").append(trustType).append(") ").append(trustLocation);
  512.                 }
  513.                 
  514.                 String trustCRL = getProperty(CostantiConnettori.CONNETTORE_HTTPS_TRUST_STORE_CRLS, connettore.getPropertyList());
  515.                 if(trustCRL!=null) {
  516.                     sb.append(newLine);
  517.                     sb.append(CostantiLabel.LABEL_VERIFICA_CONNETTORE_DETAILS_HTTPS_TRUSTSTORE_CRLS);
  518.                     sb.append(separator);
  519.                     sb.append(trustCRL);
  520.                 }
  521.                 
  522.                 String trustOCSP = getProperty(CostantiConnettori.CONNETTORE_HTTPS_TRUST_STORE_OCSP_POLICY, connettore.getPropertyList());
  523.                 if(trustOCSP!=null) {
  524.                     sb.append(newLine);
  525.                     sb.append(CostantiLabel.LABEL_VERIFICA_CONNETTORE_DETAILS_HTTPS_TRUSTSTORE_OCSP_POLICY);
  526.                     sb.append(separator);
  527.                     try {
  528.                         String label = OCSPManager.getInstance().getOCSPConfig(trustOCSP).getLabel();
  529.                         sb.append((label!=null && StringUtils.isNotEmpty(label)) ? label : trustOCSP);
  530.                     }catch(Throwable t) {
  531.                         sb.append(trustOCSP);   
  532.                     }
  533.                 }
  534.             }
  535.             
  536.             String keyLocation = getProperty(CostantiConnettori.CONNETTORE_HTTPS_KEY_STORE_LOCATION, connettore.getPropertyList());
  537.             if(keyLocation!=null) {
  538.                 
  539.                 sb.append(newLine);
  540.                 sb.append(CostantiLabel.LABEL_VERIFICA_CONNETTORE_DETAILS_HTTPS_KEYSTORE);
  541.                 sb.append(separator);
  542.                 
  543.                 String keyType = getProperty(CostantiConnettori.CONNETTORE_HTTPS_KEY_STORE_TYPE, connettore.getPropertyList());
  544.                 boolean hsm = HSMUtils.isKeystoreHSM(keyType);
  545.                 if(hsm) {
  546.                     keyLocation = CostantiLabel.CONNETTORE_HSM;
  547.                 }
  548.                 sb.append("(").append(keyType).append(") ").append(keyLocation);
  549.                 
  550.                 String keyAlias = getProperty(CostantiConnettori.CONNETTORE_HTTPS_KEY_ALIAS, connettore.getPropertyList());
  551.                 if(keyAlias!=null) {
  552.                     sb.append(newLine);
  553.                     sb.append(CostantiLabel.LABEL_VERIFICA_CONNETTORE_DETAILS_HTTPS_KEY_ALIAS);
  554.                     sb.append(separator);
  555.                     sb.append(keyAlias);
  556.                 }
  557.                 
  558.                 String keyBYOK = getProperty(CostantiConnettori.CONNETTORE_HTTPS_KEY_STORE_BYOK_POLICY, connettore.getPropertyList());
  559.                 if(keyBYOK!=null) {
  560.                     sb.append(newLine);
  561.                     sb.append(CostantiLabel.LABEL_VERIFICA_CONNETTORE_DETAILS_HTTPS_KEYSTORE_BYOK_POLICY);
  562.                     sb.append(separator);
  563.                     try {
  564.                         String label = BYOKManager.getInstance().getKMSConfigByType(keyBYOK).getLabel();
  565.                         sb.append((label!=null && StringUtils.isNotEmpty(label)) ? label : keyBYOK);
  566.                     }catch(Exception t) {
  567.                         sb.append(keyBYOK); 
  568.                     }
  569.                 }
  570.             }
  571.         }
  572.         
  573.         if(TipiConnettore.HTTP.getNome().equals(connettore.getTipo()) || TipiConnettore.HTTPS.getNome().equals(connettore.getTipo())){
  574.             String proxyHostname = getProperty(CostantiConnettori.CONNETTORE_HTTP_PROXY_HOSTNAME, connettore.getPropertyList());
  575.             if(proxyHostname!=null) {
  576.                 sb.append(newLine);
  577.                 sb.append(CostantiLabel.LABEL_VERIFICA_CONNETTORE_DETAILS_PROXY);
  578.                 sb.append(separator);
  579.                 String proxyPort = getProperty(CostantiConnettori.CONNETTORE_HTTP_PROXY_PORT, connettore.getPropertyList());
  580.                 if(proxyPort!=null) {
  581.                     sb.append(proxyHostname).append(":").append(proxyPort);
  582.                 }
  583.             }
  584.         }
  585.         
  586.         if(TipiConnettore.JMS.getNome().equals(connettore.getTipo())){
  587.              
  588.             String username = null;
  589.             if(invCredenziali!=null){
  590.                 username = invCredenziali.getUser();
  591.             }
  592.             else{
  593.                 username = getProperty(CostantiConnettori.CONNETTORE_USERNAME, connettore.getPropertyList());
  594.             }
  595.             if(username!=null) {
  596.                 sb.append(newLine);
  597.                 sb.append(CostantiLabel.LABEL_CONNETTORE_JMS_USERNAME);
  598.                 sb.append(separator);
  599.                 sb.append(username);
  600.             }
  601.             
  602.         }

  604.         if(TipiConnettore.FILE.getNome().equals(connettore.getTipo())){
  605.             
  606.             String f = getProperty(CostantiConnettori.CONNETTORE_FILE_REQUEST_OUTPUT_FILE_HEADERS, connettore.getPropertyList());
  607.             if(f!=null) {
  608.                 sb.append(newLine);
  609.                 sb.append(CostantiLabel.LABEL_OUTPUT_FILE_HEADER);
  610.                 sb.append(separator);
  611.                 sb.append(f);
  612.             }
  613.             
  614.             f = getProperty(CostantiConnettori.CONNETTORE_FILE_RESPONSE_INPUT_FILE, connettore.getPropertyList());
  615.             if(f!=null) {
  616.                 sb.append(newLine);
  617.                 sb.append(CostantiLabel.LABEL_INPUT_FILE);
  618.                 sb.append(separator);
  619.                 sb.append(f);
  620.             }
  621.             
  622.             f = getProperty(CostantiConnettori.CONNETTORE_FILE_RESPONSE_INPUT_FILE_HEADERS, connettore.getPropertyList());
  623.             if(f!=null) {
  624.                 sb.append(newLine);
  625.                 sb.append(CostantiLabel.LABEL_INPUT_FILE_HEADER);
  626.                 sb.append(separator);
  627.                 sb.append(f);
  628.             }
  629.         }
  630.         
  631.     }
  632.     
  633.     public static String getEndpointConnettore(org.openspcoop2.core.registry.Connettore connettore, boolean connettoreStatic) {
  634.         return getEndpointConnettore(connettore.mappingIntoConnettoreConfigurazione(), connettoreStatic);
  635.     }
  636.     public static String getEndpointConnettore(org.openspcoop2.core.config.Connettore connettore, boolean connettoreStatic) {

  638.         if(connettoreStatic) {
  639.             return null; // non visualizzo nulla
  640.         }
  641.         
  642.         TipiConnettore tipo = TipiConnettore.toEnumFromName(connettore.getTipo());
  643.         if(tipo==null) {
  644.             tipo = TipiConnettore.CUSTOM;
  645.         }
  646.         
  647.         String endpoint = null;
  648.         if(TipiConnettore.HTTP.getNome().equals(connettore.getTipo()) || TipiConnettore.HTTPS.getNome().equals(connettore.getTipo())){
  649.             endpoint = getProperty(CostantiConnettori.CONNETTORE_LOCATION, connettore.getPropertyList());
  650.         }
  651.         else if(TipiConnettore.JMS.getNome().equals(connettore.getTipo())){
  652.             endpoint = getProperty(CostantiConnettori.CONNETTORE_LOCATION, connettore.getPropertyList());
  653.         }
  654.         else if(TipiConnettore.FILE.getNome().equals(connettore.getTipo())){
  655.             endpoint = getProperty(CostantiConnettori.CONNETTORE_FILE_REQUEST_OUTPUT_FILE, connettore.getPropertyList());
  656.         }
  657.         else if(TipiConnettore.NULL.getNome().equals(connettore.getTipo())){
  658.             endpoint = org.openspcoop2.pdd.core.connettori.ConnettoreNULL.LOCATION;
  659.         }
  660.         else if(TipiConnettore.NULLECHO.getNome().equals(connettore.getTipo())){
  661.             endpoint = org.openspcoop2.pdd.core.connettori.ConnettoreNULLEcho.LOCATION;
  662.         }
  663.         else if(TipiConnettore.STATUS.getNome().equals(connettore.getTipo())){
  664.             endpoint = org.openspcoop2.pdd.core.connettori.ConnettoreStatus.LOCATION;
  665.         }
  666.         else {
  667.             String endpointV = getProperty(CostantiConnettori.CONNETTORE_LOCATION, connettore.getPropertyList());
  668.             if(StringUtils.isNotEmpty(endpointV)) {
  669.                 endpoint = endpointV;
  670.             }
  671.         }
  672.         return endpoint;
  673.     }
  674.     
  675.     public static String getNegoziazioneTokenPolicyConnettore(org.openspcoop2.core.registry.Connettore connettore) {
  676.         return getNegoziazioneTokenPolicyConnettore(connettore.mappingIntoConnettoreConfigurazione());
  677.     }
  678.     public static String getNegoziazioneTokenPolicyConnettore(org.openspcoop2.core.config.Connettore connettore) {
  679.         return getProperty(CostantiConnettori.CONNETTORE_TOKEN_POLICY, connettore.getPropertyList());
  680.     }
  681.     
  682.     public static String getNegoziazioneTokenEndpoint(GenericProperties gp, Logger log) {
  683.         PolicyNegoziazioneToken policy = null;
  684.         try {
  685.             policy = TokenUtilities.convertTo(gp);
  686.             return policy.getEndpoint();
  687.         }catch(Exception e) {
  688.             log.error("Errore durante il reperimento dell'endpoint della policy '"+gp.getNome()+"': "+e.getMessage(),e);
  689.             return null;
  690.         }
  691.     }
  692.     
  693.     private static String getProperty(String nome,List<org.openspcoop2.core.config.Property> list){
  694.         if(list!=null && list.size()>0){
  695.             for (org.openspcoop2.core.config.Property property : list) {
  696.                 if(property.getNome().equals(nome)){
  697.                     return property.getValore();
  698.                 }
  699.             }
  700.         }
  701.         return null;
  702.     }
  703.     
  704.     
  705.     public static String getNomeConnettori(Context context) {
  706.         String connettoriMultipli = null;
  707.         if(context.containsKey(org.openspcoop2.core.constants.Costanti.CONSEGNA_MULTIPLA_CONNETTORI_BY_ID)) {
  708.             Object oConnettori = context.getObject(org.openspcoop2.core.constants.Costanti.CONSEGNA_MULTIPLA_CONNETTORI_BY_ID );
  709.             if (oConnettori instanceof List){
  710.                 List<?> l = (List<?>) oConnettori;
  711.                 String s = getNomeConnettori(l);
  712.                 if(s!=null && s.length()>0) {
  713.                     return s;
  714.                 }
  715.             }
  716.         }
  717.         return connettoriMultipli;
  718.     }
  719.     private static String getNomeConnettori(List<?> l) {
  720.         if(!l.isEmpty()) {
  721.             StringBuilder sb = new StringBuilder();
  722.             for (Object object : l) {
  723.                 if(object instanceof String) {
  724.                     String s = (String) object;
  725.                     if(sb.length()>0) {
  726.                         sb.append(",");
  727.                     }
  728.                     sb.append(s);
  729.                 }
  730.             }
  731.             if(sb.length()>0) {
  732.                 return sb.toString();
  733.             }
  734.         }
  735.         return null;
  736.     }
  737. }
Created with JaCoCo 0.8.8.202204050719