ModIUtilities.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.protocol.modipa.utils;

  23. import java.util.ArrayList;
  24. import java.util.List;
  25. import java.util.Map;
  26. import java.util.Properties;

  28. import javax.xml.namespace.QName;
  29. import javax.xml.soap.SOAPHeader;
  30. import javax.xml.soap.SOAPHeaderElement;

  32. import org.apache.commons.lang.StringUtils;
  33. import org.openspcoop2.core.config.CanaliConfigurazione;
  34. import org.openspcoop2.core.config.PortaApplicativa;
  35. import org.openspcoop2.core.config.PortaDelegata;
  36. import org.openspcoop2.core.config.constants.RuoloContesto;
  37. import org.openspcoop2.core.id.IDAccordo;
  38. import org.openspcoop2.core.id.IDPortTypeAzione;
  39. import org.openspcoop2.core.id.IDPortaApplicativa;
  40. import org.openspcoop2.core.id.IDPortaDelegata;
  41. import org.openspcoop2.core.id.IDResource;
  42. import org.openspcoop2.core.id.IDServizio;
  43. import org.openspcoop2.core.id.IDSoggetto;
  44. import org.openspcoop2.core.mapping.MappingErogazionePortaApplicativa;
  45. import org.openspcoop2.core.mapping.MappingFruizionePortaDelegata;
  46. import org.openspcoop2.core.registry.AccordoServizioParteComune;
  47. import org.openspcoop2.core.registry.Resource;
  48. import org.openspcoop2.core.registry.constants.ServiceBinding;
  49. import org.openspcoop2.core.registry.driver.IDAccordoFactory;
  50. import org.openspcoop2.message.OpenSPCoop2SoapMessage;
  51. import org.openspcoop2.message.constants.MessageType;
  52. import org.openspcoop2.message.soap.SoapUtils;
  53. import org.openspcoop2.message.xml.MessageXMLUtils;
  54. import org.openspcoop2.pdd.config.ConfigurazionePdDManager;
  55. import org.openspcoop2.pdd.config.UrlInvocazioneAPI;
  56. import org.openspcoop2.pdd.core.autorizzazione.canali.CanaliUtils;
  57. import org.openspcoop2.pdd.core.dynamic.DynamicUtils;
  58. import org.openspcoop2.protocol.engine.SecurityTokenUtilities;
  59. import org.openspcoop2.protocol.engine.utils.NamingUtils;
  60. import org.openspcoop2.protocol.modipa.config.ModIProperties;
  61. import org.openspcoop2.protocol.modipa.constants.ModICostanti;
  62. import org.openspcoop2.protocol.sdk.Busta;
  63. import org.openspcoop2.protocol.sdk.Context;
  64. import org.openspcoop2.protocol.sdk.IProtocolFactory;
  65. import org.openspcoop2.protocol.sdk.ProtocolException;
  66. import org.openspcoop2.protocol.sdk.SecurityToken;
  67. import org.openspcoop2.protocol.sdk.properties.ProtocolProperties;
  68. import org.openspcoop2.protocol.sdk.properties.ProtocolPropertiesUtils;
  69. import org.openspcoop2.protocol.sdk.registry.ProtocolFiltroRicercaPortTypeAzioni;
  70. import org.openspcoop2.protocol.sdk.registry.ProtocolFiltroRicercaRisorse;
  71. import org.openspcoop2.protocol.sdk.registry.ProtocolFiltroRicercaServizi;
  72. import org.openspcoop2.protocol.sdk.registry.IConfigIntegrationReader;
  73. import org.openspcoop2.protocol.sdk.registry.IRegistryReader;
  74. import org.openspcoop2.protocol.sdk.registry.RegistryNotFound;
  75. import org.openspcoop2.protocol.sdk.state.IState;
  76. import org.openspcoop2.protocol.sdk.state.RequestInfo;
  77. import org.openspcoop2.utils.MapKey;
  78. import org.openspcoop2.utils.Utilities;
  79. import org.openspcoop2.utils.UtilsMultiException;
  80. import org.openspcoop2.utils.regexp.RegularExpressionEngine;
  81. import org.slf4j.Logger;
  82. import org.w3c.dom.Element;
  83. import org.w3c.dom.Node;
  84. import org.w3c.dom.NodeList;

  86. /**
  87.  * ModIImbustamentoUtilities
  88.  *
  89.  * @author Poli Andrea (apoli@link.it)
  90.  * @author $Author$
  91.  * @version $Rev$, $Date$
  92.  */
  93. public class ModIUtilities {
  94.     
  95.     private ModIUtilities() {}

  97.     private static void logError(Logger log, String msg) {
  98.         log.error(msg);
  99.     }
  100.     
  101.     public static final boolean REMOVE = true;
  102.     public static boolean exists(Properties p, String key) {
  103.         return get(p, key, false) !=null;
  104.     }
  105.     public static String get(Properties p, String key, boolean remove) {
  106.         if(p==null || p.isEmpty()) {
  107.             return null;
  108.         }
  109.         for (Object oKeyP : p.keySet()) {
  110.             if(oKeyP instanceof String) {
  111.                 String keyP = (String) oKeyP;
  112.                 if(keyP.equalsIgnoreCase(key)) {
  113.                     String s = p.getProperty(keyP);
  114.                     if(remove) {
  115.                         p.remove(keyP);
  116.                     }
  117.                     return s;
  118.                 }
  119.             }
  120.         }
  121.         return null;
  122.     }
  123.     public static void remove(Properties p, String key) {
  124.         if(p==null || p.isEmpty()) {
  125.             return;
  126.         }
  127.         for (Object oKeyP : p.keySet()) {
  128.             if(oKeyP instanceof String) {
  129.                 String keyP = (String) oKeyP;
  130.                 if(keyP.equalsIgnoreCase(key)) {
  131.                     p.remove(keyP);
  132.                     break;
  133.                 }
  134.             }
  135.         }
  136.     }
  137.     
  138.     public static List<String> getArrayStringAsList(String v, boolean deleteQuote) {
  139.         List<String> l = null;
  140.         if(v!=null && v.startsWith("[") && v.endsWith("]") && v.length()>2) {
  141.             String newValue = v.substring(1, v.length()-1);
  142.             return ModIUtilities.getAsList(newValue, deleteQuote);
  143.         }
  144.         return l;
  145.     }
  146.     public static List<String> getAsList(String values, boolean deleteQuote){
  147.         List<String> l = new ArrayList<>();
  148.         if(values.contains(",")) {
  149.             String [] tmp = values.split(",");
  150.             convertAsListValue(l, tmp, deleteQuote);
  151.         }
  152.         else {
  153.             String v = values;
  154.             if(deleteQuote && v.startsWith("\"") && v.endsWith("\"") && v.length()>2) {
  155.                 v = v.substring(1, v.length()-1);
  156.             }
  157.             l.add(v);
  158.         }
  159.         return l;
  160.     }
  161.     private static void convertAsListValue(List<String> l, String [] tmp, boolean deleteQuote) {
  162.         if(tmp!=null && tmp.length>0) {
  163.             for (String v : tmp) {
  164.                 v = v.trim();
  165.                 if(deleteQuote && v.startsWith("\"") && v.endsWith("\"") && v.length()>2) {
  166.                     v = v.substring(1, v.length()-1);
  167.                 }
  168.                 if(StringUtils.isNotEmpty(v)) {
  169.                     l.add(v);
  170.                 }
  171.             }
  172.         }
  173.     }
  174.     
  175.     public static String extractCorrelationIdFromLocation(String resourcePath, String location, boolean throwException, Logger log) throws ProtocolException {
  176.         if(resourcePath==null) {
  177.             throw new ProtocolException("Resource path della risorsa correlata non trovato");
  178.         }
  179.         
  180.         String [] rSplit = resourcePath.split("/");
  181.         int lastDynamicPosition = -1;
  182.         for (String r : rSplit) {
  183.             if(r.startsWith("{")) {
  184.                 lastDynamicPosition++;
  185.             }
  186.         }
  187.         
  188.         int lastDynamicPos = 0;
  189.         StringBuilder sb = new StringBuilder();
  190.         for (String r : rSplit) {
  191.             if(r==null || "".equals(r)) {
  192.                 continue;
  193.             }
  194.             sb.append("/+");
  195.             if(r.startsWith("{")) {
  196.                 if(lastDynamicPos == lastDynamicPosition) {
  197.                     sb.append("([^/]+)");
  198.                 }
  199.                 else {
  200.                     sb.append(".*");
  201.                 }
  202.                 lastDynamicPos++;
  203.             }
  204.             else {
  205.                 sb.append(r);
  206.             }
  207.         }
  208.         sb.append("/?");
  209.         String pattern = sb.toString();
  210.         
  211.         try {
  212.             return RegularExpressionEngine.getStringFindPattern(location, pattern);
  213.         }catch(Exception e) {
  214.             logError(log,"Estrazione Id Correlazione dalla Location '"+location+"' non riuscita (resourcePath: "+resourcePath+") (pattern: "+pattern+")");
  215.             if(throwException) {
  216.                 throw new ProtocolException(e.getMessage(),e);
  217.             }
  218.         }
  219.         
  220.         return null;
  221.     }
  222.     
  223.     public static String extractCorrelationId(String location, AccordoServizioParteComune apiContenenteRisorsa, 
  224.             String azione, String asyncInteractionRole, Logger log) throws ProtocolException {
  225.         if(location!=null) {
  226.             location = location.trim();
  227.             
  228.             String resourcePath = null;
  229.             if(ModICostanti.MODIPA_PROFILO_INTERAZIONE_ASINCRONA_RUOLO_VALUE_RICHIESTA.equals(asyncInteractionRole)) {
  230.                 for (Resource r : apiContenenteRisorsa.getResourceList()) {
  231.                     if(r.getNome().equals(azione)) {
  232.                         continue;
  233.                     }
  234.                     String ruolo = ProtocolPropertiesUtils.getOptionalStringValuePropertyRegistry(r.getProtocolPropertyList(), 
  235.                             ModICostanti.MODIPA_PROFILO_INTERAZIONE_ASINCRONA_RUOLO);
  236.                     if(ruolo!=null && ModICostanti.MODIPA_PROFILO_INTERAZIONE_ASINCRONA_RUOLO_VALUE_RICHIESTA_STATO.equals(ruolo)) {
  237.                         String actionCorrelata = ProtocolPropertiesUtils.getOptionalStringValuePropertyRegistry(r.getProtocolPropertyList(), 
  238.                                 ModICostanti.MODIPA_PROFILO_INTERAZIONE_ASINCRONA_AZIONE_RICHIESTA_CORRELATA);  
  239.                         if(actionCorrelata!=null && actionCorrelata.equals(azione)) {
  240.                             resourcePath = r.getPath();
  241.                             break;
  242.                         }
  243.                     }
  244.                     
  245.                 }
  246.             }
  247.             else if(ModICostanti.MODIPA_PROFILO_INTERAZIONE_ASINCRONA_RUOLO_VALUE_RICHIESTA_STATO.equals(asyncInteractionRole)) {
  248.                 
  249.                 String azioneRichiesta = null;
  250.                 if(ModICostanti.MODIPA_PROFILO_INTERAZIONE_ASINCRONA_RUOLO_VALUE_RICHIESTA_STATO.equals(asyncInteractionRole)) {
  251.                     Resource rRichiestaStato = null;
  252.                     for (Resource r : apiContenenteRisorsa.getResourceList()) {
  253.                         if(r.getNome().equals(azione)) {
  254.                             rRichiestaStato = r;
  255.                             break;
  256.                         }
  257.                     }
  258.                     if(rRichiestaStato==null) {
  259.                         throw new ProtocolException("Risorsa con ruolo 'Richiesta Stato' non trovata");
  260.                     }
  261.                     azioneRichiesta = ProtocolPropertiesUtils.getRequiredStringValuePropertyRegistry(rRichiestaStato.getProtocolPropertyList(), 
  262.                             ModICostanti.MODIPA_PROFILO_INTERAZIONE_ASINCRONA_AZIONE_RICHIESTA_CORRELATA);  
  263.                 }
  264.                 
  265.                 for (Resource r : apiContenenteRisorsa.getResourceList()) {
  266.                     if(!r.getNome().equals(azioneRichiesta)) {
  267.                         String ruolo = ProtocolPropertiesUtils.getOptionalStringValuePropertyRegistry(r.getProtocolPropertyList(), 
  268.                                 ModICostanti.MODIPA_PROFILO_INTERAZIONE_ASINCRONA_RUOLO);
  269.                         if(ruolo!=null && ModICostanti.MODIPA_PROFILO_INTERAZIONE_ASINCRONA_RUOLO_VALUE_RISPOSTA.equals(ruolo)) {
  270.                             String actionCorrelata = ProtocolPropertiesUtils.getOptionalStringValuePropertyRegistry(r.getProtocolPropertyList(), 
  271.                                     ModICostanti.MODIPA_PROFILO_INTERAZIONE_ASINCRONA_AZIONE_RICHIESTA_CORRELATA);  
  272.                             if(actionCorrelata!=null && actionCorrelata.equals(azioneRichiesta)) {
  273.                                 resourcePath = r.getPath();
  274.                                 break;
  275.                             }
  276.                         }
  277.                     }
  278.                 }
  279.             }
  280.              
  281.             if(resourcePath==null) {
  282.                 throw new ProtocolException("Resource path della risorsa correlata non trovato");
  283.             }
  284.             return ModIUtilities.extractCorrelationIdFromLocation(resourcePath, location, false, log);
  285.                         
  286.         }
  287.         return null;
  288.     }
  289.     
  290.     public static String getReplyToErogazione(IDSoggetto idSoggettoErogatoreServizioCorrelato, 
  291.             AccordoServizioParteComune aspc, String portType, String azione,
  292.             IRegistryReader registryReader, IConfigIntegrationReader configIntegrationReader, 
  293.             IProtocolFactory<?> protocolFactory, IState state, RequestInfo requestInfo) throws ProtocolException {
  294.         return getReplyTo(false, null, idSoggettoErogatoreServizioCorrelato, 
  295.                 aspc, portType, azione,
  296.                 registryReader, configIntegrationReader, 
  297.                 protocolFactory, state, requestInfo);
  298.     }
  299.     public static String getReplyToFruizione(IDSoggetto idSoggettoFrutore, IDSoggetto idSoggettoErogatoreServizioCorrelato, 
  300.             AccordoServizioParteComune aspc, String portType, String azione,
  301.             IRegistryReader registryReader, IConfigIntegrationReader configIntegrationReader, 
  302.             IProtocolFactory<?> protocolFactory, IState state, RequestInfo requestInfo) throws ProtocolException {
  303.         return getReplyTo(true, idSoggettoFrutore, idSoggettoErogatoreServizioCorrelato, 
  304.                 aspc, portType, azione,
  305.                 registryReader, configIntegrationReader, 
  306.                 protocolFactory, state, requestInfo);
  307.     }
  308.     private static String getReplyTo(boolean fruizione, IDSoggetto idSoggettoFrutore, IDSoggetto idSoggettoErogatoreServizioCorrelato, 
  309.             AccordoServizioParteComune aspc, String portType, String azione,
  310.             IRegistryReader registryReader, IConfigIntegrationReader configIntegrationReader, 
  311.             IProtocolFactory<?> protocolFactory, IState state, RequestInfo requestInfo) throws ProtocolException {
  312.         
  313.         try {
  314.         
  315.             if(configIntegrationReader!=null) {
  316.                 // nop
  317.             }
  318.             
  319.             String uriAPC = IDAccordoFactory.getInstance().getUriFromAccordo(aspc);
  320.             boolean rest = ServiceBinding.REST.equals(aspc.getServiceBinding());
  321.             
  322.             IDAccordo idAccordoRisposta = null;
  323.             String portTypeRisposta = null;
  324.             
  325.             if(rest) {
  326.                 ProtocolFiltroRicercaRisorse filtroRisorse = new ProtocolFiltroRicercaRisorse();
  327.                 filtroRisorse.setProtocolPropertiesRisorsa(new ProtocolProperties());
  328.                 filtroRisorse.getProtocolPropertiesRisorsa().addProperty(ModICostanti.MODIPA_PROFILO_INTERAZIONE_ASINCRONA_RUOLO, 
  329.                         ModICostanti.MODIPA_PROFILO_INTERAZIONE_ASINCRONA_RUOLO_VALUE_RISPOSTA);
  330.                 filtroRisorse.getProtocolPropertiesRisorsa().addProperty(ModICostanti.MODIPA_PROFILO_INTERAZIONE_ASINCRONA_API_RICHIESTA_CORRELATA, 
  331.                         uriAPC);
  332.                 filtroRisorse.getProtocolPropertiesRisorsa().addProperty(ModICostanti.MODIPA_PROFILO_INTERAZIONE_ASINCRONA_AZIONE_RICHIESTA_CORRELATA, 
  333.                         azione);
  334.                 List<IDResource> l = null;
  335.                 try {
  336.                     l = registryReader.findIdResourceAccordo(filtroRisorse);
  337.                 }catch(RegistryNotFound notFound) {
  338.                     // ignore
  339.                 }
  340.                 if(l==null || l.isEmpty()) {
  341.                     throw new RegistryNotFound("Non รจ stata individuata alcun API contenente una risorsa correlata alla richiesta in corso");
  342.                 }
  343.                 if(l.size()>1) {
  344.                     throw new RegistryNotFound("Sono state individuate piรน di una risorsa contenente una correlazione verso la richiesta in corso: "+l);
  345.                 }
  346.                 IDResource idResource = l.get(0);
  347.                 idAccordoRisposta = idResource.getIdAccordo();
  348.             }
  349.             else {
  350.                 ProtocolFiltroRicercaPortTypeAzioni filtroPTAzioni = new ProtocolFiltroRicercaPortTypeAzioni();
  351.                 filtroPTAzioni.setProtocolPropertiesAzione(new ProtocolProperties());
  352.                 filtroPTAzioni.getProtocolPropertiesAzione().addProperty(ModICostanti.MODIPA_PROFILO_INTERAZIONE_ASINCRONA_RUOLO, 
  353.                         ModICostanti.MODIPA_PROFILO_INTERAZIONE_ASINCRONA_RUOLO_VALUE_RISPOSTA);
  354.                 filtroPTAzioni.getProtocolPropertiesAzione().addProperty(ModICostanti.MODIPA_PROFILO_INTERAZIONE_ASINCRONA_API_RICHIESTA_CORRELATA, 
  355.                         uriAPC);
  356.                 filtroPTAzioni.getProtocolPropertiesAzione().addProperty(ModICostanti.MODIPA_PROFILO_INTERAZIONE_ASINCRONA_SERVIZIO_RICHIESTA_CORRELATA, 
  357.                         portType);
  358.                 filtroPTAzioni.getProtocolPropertiesAzione().addProperty(ModICostanti.MODIPA_PROFILO_INTERAZIONE_ASINCRONA_AZIONE_RICHIESTA_CORRELATA, 
  359.                         azione);
  360.                 List<IDPortTypeAzione> l = null;
  361.                 try {
  362.                     l = registryReader.findIdAzionePortType(filtroPTAzioni);
  363.                 }catch(RegistryNotFound notFound) {
  364.                 }
  365.                 if(l==null || l.isEmpty()) {
  366.                     throw new RegistryNotFound("Non รจ stata individuata alcun API contenente un'azione correlata alla richiesta in corso");
  367.                 }
  368.                 if(l.size()>1) {
  369.                     throw new RegistryNotFound("Sono state individuate piรน di un'azione contenente una correlazione verso la richiesta in corso: "+l);
  370.                 }
  371.                 IDPortTypeAzione idPTAzione = l.get(0);
  372.                 idAccordoRisposta = idPTAzione.getIdPortType().getIdAccordo();
  373.                 portTypeRisposta = idPTAzione.getIdPortType().getNome();
  374.             }
  375.                 
  376.             ProtocolFiltroRicercaServizi filtroServizi = new ProtocolFiltroRicercaServizi(); 
  377.             filtroServizi.setIdAccordoServizioParteComune(idAccordoRisposta);
  378.             filtroServizi.setSoggettoErogatore(idSoggettoErogatoreServizioCorrelato);
  379.             if(!rest) {
  380.                 filtroServizi.setPortType(portTypeRisposta);
  381.             }
  382.             List<IDServizio> lIdServizio = null;
  383.             try {
  384.                 lIdServizio = registryReader.findIdAccordiServizioParteSpecifica(filtroServizi);
  385.             }catch(RegistryNotFound notFound) {
  386.             }
  387.             if(lIdServizio==null || lIdServizio.isEmpty()) {
  388.                 if(fruizione) {
  389.                     throw new RegistryNotFound("Non รจ stata individuata alcuna fruzione verso l'API "+NamingUtils.getLabelAccordoServizioParteComune(idAccordoRisposta)+
  390.                             " erogata dal soggetto "+NamingUtils.getLabelSoggetto(idSoggettoErogatoreServizioCorrelato));
  391.                 }
  392.                 else {
  393.                     throw new RegistryNotFound("Non รจ stata individuata alcun'erogazione da parte del soggetto "+NamingUtils.getLabelSoggetto(idSoggettoErogatoreServizioCorrelato)+
  394.                         " relativamente all'API "+NamingUtils.getLabelAccordoServizioParteComune(idAccordoRisposta));
  395.                 }
  396.             }
  397.             if(lIdServizio.size()>1) {
  398.                 if(fruizione) {
  399.                     throw new RegistryNotFound("Sono state individuate piรน fruzioni verso l'API "+NamingUtils.getLabelAccordoServizioParteComune(idAccordoRisposta)+
  400.                             " erogata dal soggetto "+NamingUtils.getLabelSoggetto(idSoggettoErogatoreServizioCorrelato));
  401.                 }
  402.                 else {
  403.                     throw new RegistryNotFound("Sono state individuate piรน di un'erogazione da parte del soggetto "+NamingUtils.getLabelSoggetto(idSoggettoErogatoreServizioCorrelato)+
  404.                         " relativamente all'API "+NamingUtils.getLabelAccordoServizioParteComune(idAccordoRisposta));
  405.                 }
  406.             }
  407.             IDServizio idServizioCorrelato = lIdServizio.get(0);
  408.             
  409.             if(fruizione) {
  410.                 List<MappingFruizionePortaDelegata> listMapping = ConfigurazionePdDManager.getInstance(state).getMappingFruizionePortaDelegataList(idSoggettoFrutore, idServizioCorrelato, requestInfo);
  411.                 if(listMapping==null) {
  412.                     throw new RegistryNotFound("(outbound empty) Non รจ stata individuata alcuna fruzione da parte del soggetto "+NamingUtils.getLabelSoggetto(idSoggettoFrutore)+
  413.                             " verso l'API "+NamingUtils.getLabelAccordoServizioParteComune(idAccordoRisposta)+
  414.                             " erogata dal soggetto "+NamingUtils.getLabelSoggetto(idSoggettoErogatoreServizioCorrelato));
  415.                 }
  416.                 String nomePD = null;
  417.                 IDSoggetto proprietarioPD = null;
  418.                 for (MappingFruizionePortaDelegata mappingFruizionePortaDelegata : listMapping) {
  419.                     if(mappingFruizionePortaDelegata.isDefault()) {
  420.                         nomePD = mappingFruizionePortaDelegata.getIdPortaDelegata().getNome();
  421.                         proprietarioPD = idSoggettoFrutore;
  422.                     }
  423.                 }
  424.                 if(nomePD==null) {
  425.                     throw new RegistryNotFound("(outbound) Non รจ stata individuata alcuna fruzione da parte del soggetto "+NamingUtils.getLabelSoggetto(idSoggettoFrutore)+
  426.                             " verso l'API "+NamingUtils.getLabelAccordoServizioParteComune(idAccordoRisposta)+
  427.                             " erogata dal soggetto "+NamingUtils.getLabelSoggetto(idSoggettoErogatoreServizioCorrelato));
  428.                 }
  429.                 return getUrlInvocazione(protocolFactory, state, requestInfo,
  430.                         rest, aspc, RuoloContesto.PORTA_DELEGATA, nomePD, proprietarioPD);
  431.             }
  432.             else {
  433.                 List<MappingErogazionePortaApplicativa> listMapping = ConfigurazionePdDManager.getInstance(state).getMappingErogazionePortaApplicativaList(idServizioCorrelato, requestInfo);
  434.                 if(listMapping==null) {
  435.                     throw new RegistryNotFound("(inbound empty) Non รจ stata individuata alcun'erogazione da parte del soggetto "+NamingUtils.getLabelSoggetto(idSoggettoErogatoreServizioCorrelato)+
  436.                             " relativamente all'API "+NamingUtils.getLabelAccordoServizioParteComune(idAccordoRisposta));
  437.                 }
  438.                 String nomePA = null;
  439.                 IDSoggetto proprietarioPA = null;
  440.                 for (MappingErogazionePortaApplicativa mappingErogazionePortaApplicativa : listMapping) {
  441.                     if(mappingErogazionePortaApplicativa.isDefault()) {
  442.                         nomePA = mappingErogazionePortaApplicativa.getIdPortaApplicativa().getNome();
  443.                         proprietarioPA = idServizioCorrelato.getSoggettoErogatore();
  444.                     }
  445.                 }
  446.                 if(nomePA==null) {
  447.                     throw new RegistryNotFound("(inbound) Non รจ stata individuata alcun'erogazione da parte del soggetto "+NamingUtils.getLabelSoggetto(idSoggettoErogatoreServizioCorrelato)+
  448.                             " relativamente all'API "+NamingUtils.getLabelAccordoServizioParteComune(idAccordoRisposta));
  449.                 }
  450.                 return getUrlInvocazione(protocolFactory, state, requestInfo,
  451.                         rest, aspc, RuoloContesto.PORTA_APPLICATIVA, nomePA, proprietarioPA);
  452.             }
  453.         }catch(Exception e) {
  454.             throw new ProtocolException(e.getMessage(),e);
  455.         }
  456.     }
  457.     
  458.     
  459.     public static String getUrlInvocazione(IProtocolFactory<?> protocolFactory, IState state, RequestInfo requestInfo,
  460.             boolean rest, AccordoServizioParteComune aspc, RuoloContesto ruoloContesto, String nomePorta, IDSoggetto proprietarioPorta) throws ProtocolException {
  461.         try {
  462.             List<String> tags = new ArrayList<>();
  463.             if(aspc!=null && aspc.getGruppi()!=null && aspc.getGruppi().sizeGruppoList()>0) {
  464.                 for (int i = 0; i < aspc.getGruppi().sizeGruppoList(); i++) {
  465.                     tags.add(aspc.getGruppi().getGruppo(i).getNome());
  466.                 }
  467.             }
  468.             
  469.             IConfigIntegrationReader configReader = protocolFactory.getCachedConfigIntegrationReader(state, requestInfo);
  470.             CanaliConfigurazione canaliConfigurazione = configReader.getCanaliConfigurazione();
  471.             String canaleApi = null;
  472.             if(aspc!=null) {
  473.                 canaleApi = aspc.getCanale();
  474.             }
  475.             String canalePorta = null;
  476.             if(nomePorta!=null) {
  477.                 if(RuoloContesto.PORTA_APPLICATIVA.equals(ruoloContesto)) {
  478.                     try {
  479.                         IDPortaApplicativa idPA = new IDPortaApplicativa();
  480.                         idPA.setNome(nomePorta);
  481.                         PortaApplicativa pa = configReader.getPortaApplicativa(idPA);
  482.                         canalePorta = pa.getNome();
  483.                     }catch(Exception t) {
  484.                         // ignore
  485.                     }
  486.                 }
  487.                 else {
  488.                     try {
  489.                         IDPortaDelegata idPD = new IDPortaDelegata();
  490.                         idPD.setNome(nomePorta);
  491.                         PortaDelegata pd = configReader.getPortaDelegata(idPD);
  492.                         canalePorta = pd.getNome();
  493.                     }catch(Exception t) {
  494.                         // ignore
  495.                     }
  496.                 }
  497.             }
  498.             String canale = CanaliUtils.getCanale(canaliConfigurazione, canaleApi, canalePorta);
  499.             
  500.             UrlInvocazioneAPI urlInvocazioneApi = ConfigurazionePdDManager.getInstance().getConfigurazioneUrlInvocazione(protocolFactory, 
  501.                     ruoloContesto,
  502.                     rest ? org.openspcoop2.message.constants.ServiceBinding.REST : org.openspcoop2.message.constants.ServiceBinding.SOAP,
  503.                     nomePorta,
  504.                     proprietarioPorta,
  505.                     tags, canale, 
  506.                     requestInfo);        
  507.             String prefixGatewayUrl = urlInvocazioneApi.getBaseUrl();
  508.             String contesto = urlInvocazioneApi.getContext();
  509.             return Utilities.buildUrl(prefixGatewayUrl, contesto);
  510.         }catch(Exception e) {
  511.             throw new ProtocolException(e.getMessage(),e);
  512.         }
  513.     }
  514.     
  515.     public static String getSOAPHeaderReplyToValue(OpenSPCoop2SoapMessage soapMessage, boolean bufferMessageReadOnly, String idTransazione) throws ProtocolException {
  516.         boolean useSoapReader = true; // interessa solo il valore
  517.         SOAPHeaderElement hdrElement = getSOAPHeaderReplyTo(useSoapReader, soapMessage, bufferMessageReadOnly, idTransazione);
  518.         return hdrElement!=null ? hdrElement.getValue() : null;
  519.     }
  520.     public static SOAPHeaderElement getSOAPHeaderReplyTo(boolean useSoapReader, OpenSPCoop2SoapMessage soapMessage, boolean bufferMessageReadOnly, String idTransazione) throws ProtocolException {
  521.         try {
  522.             ModIProperties modIProperties = ModIProperties.getInstance();
  523.     
  524.             SOAPInfo soapInfo = new SOAPInfo();
  525.             boolean readRootElementInfo = modIProperties.useSoapBodyReplyToNamespace();
  526.             soapInfo.read(useSoapReader, soapMessage, bufferMessageReadOnly, idTransazione, 
  527.                     false, true, readRootElementInfo);
  528.             
  529.             MessageType messageType = soapMessage.getMessageType();
  530.             SOAPHeader header = soapInfo.getHeader();
  531.             String namespace = readRootElementInfo ? soapInfo.getRootElementNamespace() : modIProperties.getSoapReplyToNamespace();
  532.             
  533.             return getSOAPHeaderElement(messageType, header, modIProperties.getSoapReplyToName(), 
  534.                     namespace,
  535.                     modIProperties.getSoapReplyToActor());
  536.         }catch(Exception e) {
  537.             throw new ProtocolException(e.getMessage(),e);
  538.         }
  539.     }
  540.     public static String getSOAPHeaderCorrelationIdValue(OpenSPCoop2SoapMessage soapMessage, boolean bufferMessageReadOnly, String idTransazione) throws ProtocolException {
  541.         boolean useSoapReader = true; // interessa solo il valore
  542.         SOAPHeaderElement hdrElement = getSOAPHeaderCorrelationId(useSoapReader, soapMessage, bufferMessageReadOnly, idTransazione);
  543.         return hdrElement!=null ? hdrElement.getValue() : null;
  544.     }
  545.     public static SOAPHeaderElement getSOAPHeaderCorrelationId(boolean useSoapReader, OpenSPCoop2SoapMessage soapMessage, boolean bufferMessageReadOnly, String idTransazione) throws ProtocolException {
  546.         try {
  547.         
  548.             ModIProperties modIProperties = ModIProperties.getInstance();
  549.             
  550.             SOAPInfo soapInfo = new SOAPInfo();
  551.             boolean readRootElementInfo = modIProperties.useSoapBodyCorrelationIdNamespace();
  552.             soapInfo.read(useSoapReader, soapMessage, bufferMessageReadOnly, idTransazione, 
  553.                     false, true, readRootElementInfo);
  554.             
  555.             MessageType messageType = soapMessage.getMessageType();
  556.             SOAPHeader header = soapInfo.getHeader();
  557.             String namespace = readRootElementInfo ? soapInfo.getRootElementNamespace() : modIProperties.getSoapCorrelationIdNamespace();
  558.             
  559.             return getSOAPHeaderElement(messageType, header, modIProperties.getSoapCorrelationIdName(), 
  560.                     namespace,
  561.                     modIProperties.getSoapCorrelationIdActor());
  562.             
  563.         }catch(Exception e) {
  564.             throw new ProtocolException(e.getMessage(),e);
  565.         }
  566.     }
  567.     
  568.     public static SOAPHeaderElement getSOAPHeaderRequestDigest(boolean useSoapReader, OpenSPCoop2SoapMessage soapMessage, boolean bufferMessageReadOnly, String idTransazione) throws ProtocolException {
  569.         try {
  570.         
  571.             ModIProperties modIProperties = ModIProperties.getInstance();
  572.             
  573.             SOAPInfo soapInfo = new SOAPInfo();
  574.             boolean readRootElementInfo = modIProperties.useSoapBodyRequestDigestNamespace();
  575.             soapInfo.read(useSoapReader, soapMessage, bufferMessageReadOnly, idTransazione, 
  576.                     false, true, readRootElementInfo);
  577.             
  578.             MessageType messageType = soapMessage.getMessageType();
  579.             SOAPHeader header = soapInfo.getHeader();
  580.             String namespace = readRootElementInfo ? soapInfo.getRootElementNamespace() : modIProperties.getSoapRequestDigestNamespace();
  581.             
  582.             return getSOAPHeaderElement(messageType, header, modIProperties.getSoapRequestDigestName(), 
  583.                     namespace,
  584.                     modIProperties.getSoapRequestDigestActor());
  585.             
  586.         }catch(Exception e) {
  587.             throw new ProtocolException(e.getMessage(),e);
  588.         }
  589.     }
  590.     
  591.     public static SOAPHeaderElement getSOAPHeaderElement(MessageType messageType, SOAPHeader header, String localName, String namespace, String actor) throws ProtocolException {
  592.     
  593.         try {
  594.         
  595.             if(header==null){
  596.                 return null;
  597.             }
  598.             java.util.Iterator<?> it = header.examineAllHeaderElements();
  599.             while( it.hasNext()  ){
  600.                 // Test Header Element
  601.                 SOAPHeaderElement headerElementCheck = (SOAPHeaderElement) it.next();
  602.                 
  603.                 if(!namespace.equals(headerElementCheck.getNamespaceURI())) {
  604.                     continue;
  605.                 }
  606.                 if(!localName.equals(headerElementCheck.getLocalName())) {
  607.                     continue;
  608.                 }
  609.                 
  610.                 //Controllo Actor
  611.                 String actorCheck = SoapUtils.getSoapActor(headerElementCheck, messageType);
  612.                 if(actor==null) {
  613.                     if(actorCheck==null) {
  614.                         return headerElementCheck;
  615.                     }
  616.                 }
  617.                 else {
  618.                     if( actor.equals(actorCheck) ){
  619.                         return headerElementCheck;
  620.                     }
  621.                 }
  622.             }
  623.             
  624.             return null;
  625.             
  626.         }catch(Exception e) {
  627.             throw new ProtocolException(e.getMessage(),e);
  628.         }
  629.     }
  630.     
  631.     public static void addSOAPHeaderReplyTo(OpenSPCoop2SoapMessage soapMessage, boolean bufferMessageReadOnly, String idTransazione, String value) throws ProtocolException {
  632.         try {
  633.             ModIProperties modIProperties = ModIProperties.getInstance();
  634.             
  635.             boolean useSoapReader = true; // vengono recuperati solamente i prefissi e namespace.
  636.             SOAPInfo soapInfo = new SOAPInfo();
  637.             boolean readRootElementInfo = modIProperties.useSoapBodyReplyToNamespace();
  638.             if(readRootElementInfo) {
  639.                 soapInfo.read(useSoapReader, soapMessage, bufferMessageReadOnly, idTransazione, 
  640.                         false, false, readRootElementInfo);
  641.             }
  642.             
  643.             addSOAPHeaderElement(soapMessage, modIProperties.getSoapReplyToName(), 
  644.                     modIProperties.useSoapBodyReplyToNamespace() ? soapInfo.getRootElementPrefix() : modIProperties.getSoapReplyToPrefix(),
  645.                     modIProperties.useSoapBodyReplyToNamespace() ? soapInfo.getRootElementNamespace() : modIProperties.getSoapReplyToNamespace(),
  646.                     modIProperties.getSoapReplyToActor(),
  647.                     modIProperties.isSoapReplyToMustUnderstand(),
  648.                     value);
  649.         }catch(Exception e) {
  650.             throw new ProtocolException(e.getMessage(),e);
  651.         }
  652.     }
  653.     public static void addSOAPHeaderCorrelationId(OpenSPCoop2SoapMessage soapMessage, boolean bufferMessageReadOnly, String idTransazione, String value) throws ProtocolException {
  654.         try {
  655.             ModIProperties modIProperties = ModIProperties.getInstance();
  656.             
  657.             boolean useSoapReader = true; // vengono recuperati solamente i prefissi e namespace.
  658.             SOAPInfo soapInfo = new SOAPInfo();
  659.             boolean readRootElementInfo = modIProperties.useSoapBodyCorrelationIdNamespace();
  660.             if(readRootElementInfo) {
  661.                 soapInfo.read(useSoapReader, soapMessage, bufferMessageReadOnly, idTransazione, 
  662.                         false, false, readRootElementInfo);
  663.             }
  664.             
  665.             addSOAPHeaderElement(soapMessage, modIProperties.getSoapCorrelationIdName(), 
  666.                     modIProperties.useSoapBodyCorrelationIdNamespace() ? soapInfo.getRootElementPrefix() : modIProperties.getSoapCorrelationIdPrefix(),
  667.                     modIProperties.useSoapBodyCorrelationIdNamespace() ? soapInfo.getRootElementNamespace() : modIProperties.getSoapCorrelationIdNamespace(),
  668.                     modIProperties.getSoapCorrelationIdActor(),
  669.                     modIProperties.isSoapCorrelationIdMustUnderstand(),
  670.                     value);
  671.         }catch(Exception e) {
  672.             throw new ProtocolException(e.getMessage(),e);
  673.         }
  674.     }
  675.     
  676.     public static SOAPHeaderElement addSOAPHeaderRequestDigest(OpenSPCoop2SoapMessage soapMessage, boolean bufferMessageReadOnly, String idTransazione, NodeList value) throws ProtocolException {
  677.         try {
  678.             ModIProperties modIProperties = ModIProperties.getInstance();
  679.             
  680.             boolean useSoapReader = true; // vengono recuperati solamente i prefissi e namespace.
  681.             SOAPInfo soapInfo = new SOAPInfo();
  682.             boolean readRootElementInfo = modIProperties.useSoapBodyRequestDigestNamespace();
  683.             if(readRootElementInfo) {
  684.                 soapInfo.read(useSoapReader, soapMessage, bufferMessageReadOnly, idTransazione, 
  685.                         false, false, readRootElementInfo);
  686.             }
  687.             
  688.             return addSOAPHeaderElement(soapMessage, modIProperties.getSoapRequestDigestName(), 
  689.                     modIProperties.useSoapBodyRequestDigestNamespace() ? soapInfo.getRootElementPrefix() : modIProperties.getSoapRequestDigestPrefix(),
  690.                     modIProperties.useSoapBodyRequestDigestNamespace() ? soapInfo.getRootElementNamespace() : modIProperties.getSoapRequestDigestNamespace(),
  691.                     modIProperties.getSoapRequestDigestActor(),
  692.                     modIProperties.isSoapRequestDigestMustUnderstand(),
  693.                     value);
  694.         }catch(Exception e) {
  695.             throw new ProtocolException(e.getMessage(),e);
  696.         }
  697.     }
  698.     
  699.     public static SOAPHeaderElement addSOAPHeaderElement(OpenSPCoop2SoapMessage msg, String localName, String prefix, String namespace, String actor, boolean mustUnderstand, Object value) throws ProtocolException {
  700.         
  701.         try {
  702.         
  703.             // se gia esiste aggiorno il valore
  704.             SOAPHeaderElement hdrElement = getSOAPHeaderElement(msg.getMessageType(), msg.getSOAPHeader(), localName, namespace, actor);
  705.             
  706.             if(hdrElement==null) {
  707.                 SOAPHeader header = msg.getSOAPHeader();
  708.                 if(header==null){
  709.                     header = msg.getSOAPPart().getEnvelope().addHeader();
  710.                 }
  711.                 hdrElement = msg.newSOAPHeaderElement(header, new QName(namespace,localName,prefix));
  712.     
  713.                 if(actor!=null && !"".equals(actor)) {
  714.                     hdrElement.setActor(actor);
  715.                 }
  716.                 hdrElement.setMustUnderstand(mustUnderstand);
  717.                     
  718.                 msg.addHeaderElement(header, hdrElement);
  719.             }
  720.             if(value instanceof String) {
  721.                 hdrElement.setValue( (String) value);
  722.             }
  723.             else {
  724.                 NodeList nodeList = (NodeList) value;
  725.                 for (int i = 0; i < nodeList.getLength(); i++) {
  726.                     Node n = nodeList.item(i);
  727.                     byte[] ref = msg.getAsByte(n, false);
  728.                     Element element = MessageXMLUtils.getInstance(msg.getFactory()).newElement(ref);
  729.                     hdrElement.addChildElement(SoapUtils.getSoapFactory(msg.getFactory(), msg.getMessageType()).createElement(element));
  730.                 }
  731.             }
  732.         
  733.             return hdrElement;
  734.             
  735.         }catch(Exception e) {
  736.             throw new ProtocolException(e.getMessage(),e);
  737.         }
  738.     }
  739.     
  740.     public static String getDynamicValue(String tipoRisorsa, String template, Map<String, Object> dynamicMap, Context context) throws ProtocolException {
  741.         String valoreRisorsa = null;
  742.         try {
  743.             valoreRisorsa = DynamicUtils.convertDynamicPropertyValue(tipoRisorsa, template, dynamicMap, context);
  744.         }catch(Exception e) {
  745.             throw new ProtocolException("Conversione valore della risorsa ("+tipoRisorsa+") '"+template+"' non riuscita: "+e.getMessage(),e);
  746.         }
  747.         return valoreRisorsa;
  748.     }
  749.     public static String getDynamicValue(String tipoRisorsa, List<String> templates, Map<String, Object> dynamicMap, Context context) throws ProtocolException {
  750.         List<Exception> exceptions = new ArrayList<>();
  751.         for (String template : templates) {
  752.             try {
  753.                 String v = getDynamicValue(tipoRisorsa, template, dynamicMap, context);
  754.                 if(v!=null && !"".equals(v)) {
  755.                     return v;
  756.                 }
  757.             }catch(Exception t) {
  758.                 exceptions.add(t);
  759.             }
  760.         }
  761.         String errorMsg = "";
  762.         StringBuilder sb = new StringBuilder();
  763.         if(!exceptions.isEmpty()) {
  764.             for (Exception t : exceptions) {
  765.                 if(exceptions.size()>1) {
  766.                     sb.append("\n");
  767.                 }
  768.                 sb.append(t.getMessage());
  769.             }
  770.         }
  771.         if(sb.length()>0) {
  772.             errorMsg = ": "+ sb.toString();
  773.         }
  774.         UtilsMultiException multi = new UtilsMultiException("Non รจ stato possibile recuperare un valore da associare alla risorsa '"+tipoRisorsa+"'"+errorMsg, exceptions.toArray(new Throwable[1]));
  775.         throw new ProtocolException(multi.getMessage(), multi);
  776.     }
  777.     
  778.     public static void addHeaderProperty(Busta busta, String hdrName, String hdrValue) {
  779.         String pName = ModICostanti.MODIPA_BUSTA_EXT_PROFILO_SICUREZZA_MESSAGGIO_SIGNED_HEADER_PREFIX+hdrName;
  780.         String actualValue = busta.getProperty(pName);
  781.         if(actualValue!=null) {
  782.             for (int i = 2; i < 1000; i++) { // 1000 header con solito nome ?
  783.                 pName = ModICostanti.MODIPA_BUSTA_EXT_PROFILO_SICUREZZA_MESSAGGIO_SIGNED_HEADER_PREFIX+hdrName+ModICostanti.MODIPA_BUSTA_EXT_PROFILO_SICUREZZA_MESSAGGIO_SIGNED_HEADER_MULTIPLE_VALUE_SUFFIX+i;
  784.                 actualValue = busta.getProperty(pName);
  785.                 if(actualValue==null) {
  786.                     busta.addProperty(pName, hdrValue);
  787.                     break;
  788.                 }
  789.             }
  790.         }
  791.         else {
  792.             busta.addProperty(pName, hdrValue);
  793.         }
  794.     }
  795.     
  796.     private static final MapKey<String> DYNAMIC_MAP_REQUEST = org.openspcoop2.utils.Map.newMapKey("MODI_DYNAMIC_MAP_REQUEST");
  797.     public static void saveDynamicMapRequest(Context context, Map<String, Object> map){
  798.         if(context!=null && map!=null) {
  799.             context.addObject(DYNAMIC_MAP_REQUEST, map);
  800.         }
  801.     }
  802.     @SuppressWarnings("unchecked")
  803.     public static Map<String, Object> removeDynamicMapRequest(Context context){
  804.         Map<String, Object> map = null;
  805.         if(context!=null) {
  806.             Object o = context.removeObject(DYNAMIC_MAP_REQUEST);
  807.             if(o instanceof Map<?, ?>) {
  808.                 return (Map<String, Object>) o;
  809.             }
  810.         }
  811.         return map;
  812.     }
  813.     
  814.     public static SecurityToken newSecurityToken(Context context) {
  815.         return SecurityTokenUtilities.newSecurityToken(context);
  816.     }
  817.     public static SecurityToken readSecurityToken(Context context) {
  818.         return SecurityTokenUtilities.readSecurityToken(context);
  819.     }
  820. }
Created with JaCoCo 0.8.8.202204050719