UtilitiesIntegrazione.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.  */



  23. package org.openspcoop2.pdd.core.integrazione;


  26. import java.util.ArrayList;
  27. import java.util.HashMap;
  28. import java.util.Iterator;
  29. import java.util.List;
  30. import java.util.Map;
  31. import java.util.Properties;

  33. import javax.xml.namespace.QName;
  34. import javax.xml.soap.SOAPElement;
  35. import javax.xml.soap.SOAPHeader;
  36. import javax.xml.soap.SOAPHeaderElement;

  38. import org.openspcoop2.core.config.PortaApplicativa;
  39. import org.openspcoop2.core.config.PortaDelegata;
  40. import org.openspcoop2.core.config.Proprieta;
  41. import org.openspcoop2.core.constants.Costanti;
  42. import org.openspcoop2.core.id.IDPortaApplicativa;
  43. import org.openspcoop2.core.id.IDPortaDelegata;
  44. import org.openspcoop2.core.id.IDServizio;
  45. import org.openspcoop2.core.id.IDSoggetto;
  46. import org.openspcoop2.message.OpenSPCoop2MessageFactory;
  47. import org.openspcoop2.message.OpenSPCoop2MessageProperties;
  48. import org.openspcoop2.message.OpenSPCoop2SoapMessage;
  49. import org.openspcoop2.message.constants.MessageType;
  50. import org.openspcoop2.message.constants.ServiceBinding;
  51. import org.openspcoop2.message.exception.MessageNotSupportedException;
  52. import org.openspcoop2.message.soap.SoapUtils;
  53. import org.openspcoop2.message.xml.ValidatoreXSD;
  54. import org.openspcoop2.pdd.config.ConfigurazionePdDManager;
  55. import org.openspcoop2.pdd.config.CostantiProprieta;
  56. import org.openspcoop2.pdd.config.OpenSPCoop2Properties;
  57. import org.openspcoop2.pdd.core.CostantiPdD;
  58. import org.openspcoop2.pdd.core.PdDContext;
  59. import org.openspcoop2.pdd.logger.OpenSPCoop2Logger;
  60. import org.openspcoop2.protocol.sdk.state.RequestInfo;
  61. import org.openspcoop2.utils.MapKey;
  62. import org.openspcoop2.utils.transport.TransportUtils;
  63. import org.openspcoop2.utils.transport.http.HttpConstants;
  64. import org.openspcoop2.utils.xml.XSDResourceResolver;
  65. import org.slf4j.Logger;


  68. /**
  69.  * Classe contenenti utilities per le integrazioni.
  70.  *
  71.  * @author Poli Andrea (apoli@link.it)
  72.  * @author $Author$
  73.  * @version $Rev$, $Date$
  74.  */
  75. public class UtilitiesIntegrazione {


  78.     // ***** STATIC *****

  80.     private static final boolean PORTA_DELEGATA = true;
  81.     private static final boolean PORTA_APPLICATIVA = false;
  82.     private static final boolean REQUEST = true;
  83.     private static final boolean RESPONSE = false;
  84.     
  85.     private static UtilitiesIntegrazione utilitiesIntegrazionePDRequest = null;
  86.     private static UtilitiesIntegrazione utilitiesIntegrazionePDResponse = null;
  87.     private static UtilitiesIntegrazione utilitiesIntegrazionePARequest = null;
  88.     private static UtilitiesIntegrazione utilitiesIntegrazionePAResponse = null;
  89.     public static UtilitiesIntegrazione getInstancePDRequest(Logger log){
  90.         if(UtilitiesIntegrazione.utilitiesIntegrazionePDRequest==null){
  91.             // spotbugs warning 'SING_SINGLETON_GETTER_NOT_SYNCHRONIZED': l'istanza viene creata allo startup
  92.             synchronized (UtilitiesIntegrazione.class) {
  93.                 UtilitiesIntegrazione.initialize(log,PORTA_DELEGATA,REQUEST);
  94.             }
  95.         }
  96.         return UtilitiesIntegrazione.utilitiesIntegrazionePDRequest;
  97.     }
  98.     public static UtilitiesIntegrazione getInstancePDResponse(Logger log){
  99.         if(UtilitiesIntegrazione.utilitiesIntegrazionePDResponse==null){
  100.             // spotbugs warning 'SING_SINGLETON_GETTER_NOT_SYNCHRONIZED': l'istanza viene creata allo startup
  101.             synchronized (UtilitiesIntegrazione.class) {
  102.                 UtilitiesIntegrazione.initialize(log,PORTA_DELEGATA,RESPONSE);
  103.             }
  104.         }
  105.         return UtilitiesIntegrazione.utilitiesIntegrazionePDResponse;
  106.     }
  107.     public static UtilitiesIntegrazione getInstancePARequest(Logger log){
  108.         if(UtilitiesIntegrazione.utilitiesIntegrazionePARequest==null){
  109.             // spotbugs warning 'SING_SINGLETON_GETTER_NOT_SYNCHRONIZED': l'istanza viene creata allo startup
  110.             synchronized (UtilitiesIntegrazione.class) {
  111.                 UtilitiesIntegrazione.initialize(log,PORTA_APPLICATIVA,REQUEST);
  112.             }
  113.         }
  114.         return UtilitiesIntegrazione.utilitiesIntegrazionePARequest;
  115.     }
  116.     public static UtilitiesIntegrazione getInstancePAResponse(Logger log){
  117.         if(UtilitiesIntegrazione.utilitiesIntegrazionePAResponse==null){
  118.             // spotbugs warning 'SING_SINGLETON_GETTER_NOT_SYNCHRONIZED': l'istanza viene creata allo startup
  119.             synchronized (UtilitiesIntegrazione.class) {
  120.                 UtilitiesIntegrazione.initialize(log,PORTA_APPLICATIVA,RESPONSE);
  121.             }
  122.         }
  123.         return UtilitiesIntegrazione.utilitiesIntegrazionePAResponse;
  124.     }

  126.     private static synchronized void initialize(Logger log,boolean portaDelegata, boolean request){
  127.         if(portaDelegata) {
  128.             if(request) {
  129.                 if(UtilitiesIntegrazione.utilitiesIntegrazionePDRequest==null){
  130.                     UtilitiesIntegrazione.utilitiesIntegrazionePDRequest = new UtilitiesIntegrazione(log, portaDelegata, request);
  131.                 }
  132.             }
  133.             else {
  134.                 if(UtilitiesIntegrazione.utilitiesIntegrazionePDResponse==null){
  135.                     UtilitiesIntegrazione.utilitiesIntegrazionePDResponse = new UtilitiesIntegrazione(log, portaDelegata, request);
  136.                 }
  137.             }
  138.         }
  139.         else {
  140.             if(request) {
  141.                 if(UtilitiesIntegrazione.utilitiesIntegrazionePARequest==null){
  142.                     UtilitiesIntegrazione.utilitiesIntegrazionePARequest = new UtilitiesIntegrazione(log, portaDelegata, request);
  143.                 }
  144.             }
  145.             else {
  146.                 if(UtilitiesIntegrazione.utilitiesIntegrazionePAResponse==null){
  147.                     UtilitiesIntegrazione.utilitiesIntegrazionePAResponse = new UtilitiesIntegrazione(log, portaDelegata, request);
  148.                 }
  149.             }
  150.         }
  151.     }

  153.     
  154.     
  155.     
  156.     // ***** INSTANCE *****

  158.     private List<MapKey<String>> keywordsIntegrazione = null;
  159.     
  160.     private Map<MapKey<String>,String> keyValueIntegrazioneTrasporto = null;
  161.     private Map<MapKey<String>, Boolean> keySetEnabled_HeaderIntegrazioneTrasporto = null;
  162.     private Map<MapKey<String>, Boolean> keyReadEnabled_HeaderIntegrazioneTrasporto = null;
  163.     
  164.     private Map<MapKey<String>,String> keyValueIntegrazioneUrlBased = null;
  165.     private Map<MapKey<String>, Boolean> keySetEnabled_HeaderIntegrazioneUrlBased = null;
  166.     private Map<MapKey<String>, Boolean> keyReadEnabled_HeaderIntegrazioneUrlBased = null;
  167.     
  168.     private Map<MapKey<String>,String> keyValueIntegrazioneSoap = null;
  169.     private Map<MapKey<String>, Boolean> keySetEnabled_HeaderIntegrazioneSoap = null;
  170.     private Map<MapKey<String>, Boolean> keyReadEnabled_HeaderIntegrazioneSoap = null;
  171.     
  172.     private OpenSPCoop2Properties openspcoopProperties = null;
  173.     private Map<String, ValidatoreXSD> validatoreXSD_soap11_map = new HashMap<String, ValidatoreXSD>();
  174.     private Map<String, ValidatoreXSD> validatoreXSD_soap12_map = new HashMap<String, ValidatoreXSD>();
  175.     
  176.     private boolean portaDelegata;
  177.     
  178.     private boolean request;
  179.     
  180.     private Logger log;
  181.     
  182.     private UtilitiesIntegrazione(Logger log, boolean portaDelegata, boolean request){
  183.         
  184.         this.log = log;
  185.         
  186.         this.openspcoopProperties = OpenSPCoop2Properties.getInstance();
  187.         
  188.         this.portaDelegata = portaDelegata;
  189.         
  190.         this.request = request;
  191.         
  192.         this.keywordsIntegrazione = this.openspcoopProperties.getKeywordsIntegrazione();
  193.         
  194.         this.keyValueIntegrazioneTrasporto = this.openspcoopProperties.getKeyValue_HeaderIntegrazioneTrasporto();
  195.         try{
  196.             if(portaDelegata) {
  197.                 this.keySetEnabled_HeaderIntegrazioneTrasporto = this.openspcoopProperties.getKeyPDSetEnabled_HeaderIntegrazioneTrasporto(request);
  198.                 this.keyReadEnabled_HeaderIntegrazioneTrasporto = this.openspcoopProperties.getKeyPDReadEnabled_HeaderIntegrazioneTrasporto();
  199.             }
  200.             else {
  201.                 this.keySetEnabled_HeaderIntegrazioneTrasporto = this.openspcoopProperties.getKeyPASetEnabled_HeaderIntegrazioneTrasporto(request);
  202.                 this.keyReadEnabled_HeaderIntegrazioneTrasporto = this.openspcoopProperties.getKeyPAReadEnabled_HeaderIntegrazioneTrasporto();
  203.             }
  204.         }catch(Exception e){
  205.             log.error("Integrazione, errore durante la lettura del file di configurazione: "+e.getMessage(),e);
  206.         }
  207.         
  208.         this.keyValueIntegrazioneUrlBased = this.openspcoopProperties.getKeyValue_HeaderIntegrazioneUrlBased();
  209.         try{
  210.             if(portaDelegata) {
  211.                 this.keySetEnabled_HeaderIntegrazioneUrlBased = this.openspcoopProperties.getKeyPDSetEnabled_HeaderIntegrazioneUrlBased();
  212.                 this.keyReadEnabled_HeaderIntegrazioneUrlBased = this.openspcoopProperties.getKeyPDReadEnabled_HeaderIntegrazioneUrlBased();
  213.             }
  214.             else {
  215.                 this.keySetEnabled_HeaderIntegrazioneUrlBased = this.openspcoopProperties.getKeyPASetEnabled_HeaderIntegrazioneUrlBased();
  216.                 this.keyReadEnabled_HeaderIntegrazioneUrlBased = this.openspcoopProperties.getKeyPAReadEnabled_HeaderIntegrazioneUrlBased();
  217.             }
  218.         }catch(Exception e){
  219.             log.error("Integrazione, errore durante la lettura del file di configurazione: "+e.getMessage(),e);
  220.         }
  221.         
  222.         this.keyValueIntegrazioneSoap = this.openspcoopProperties.getKeyValue_HeaderIntegrazioneSoap();
  223.         try{
  224.             if(portaDelegata) {
  225.                 this.keySetEnabled_HeaderIntegrazioneSoap = this.openspcoopProperties.getKeyPDSetEnabled_HeaderIntegrazioneSoap(request);
  226.                 this.keyReadEnabled_HeaderIntegrazioneSoap = this.openspcoopProperties.getKeyPDReadEnabled_HeaderIntegrazioneSoap();
  227.             }
  228.             else {
  229.                 this.keySetEnabled_HeaderIntegrazioneSoap = this.openspcoopProperties.getKeyPASetEnabled_HeaderIntegrazioneSoap(request);
  230.                 this.keyReadEnabled_HeaderIntegrazioneSoap = this.openspcoopProperties.getKeyPAReadEnabled_HeaderIntegrazioneSoap();
  231.             }
  232.         }catch(Exception e){
  233.             log.error("Integrazione, errore durante la lettura del file di configurazione: "+e.getMessage(),e);
  234.         }
  235.         
  236.     }
  237.     
  238.     private synchronized void initValidatoreXSD(OpenSPCoop2MessageFactory messageFactory) {
  239.         String key = messageFactory.getClass().getName();
  240.             
  241.         if(!this.validatoreXSD_soap11_map.containsKey(key)) {
  242.             try{
  243.                 XSDResourceResolver xsdResourceResolver_soap11 = new XSDResourceResolver();
  244.                 xsdResourceResolver_soap11.addResource("soapEnvelope.xsd", UtilitiesIntegrazione.class.getResourceAsStream("/soapEnvelope.xsd"));
  245.                 this.validatoreXSD_soap11_map.put(key, new ValidatoreXSD(messageFactory, this.log,xsdResourceResolver_soap11,UtilitiesIntegrazione.class.getResourceAsStream("/integrazione_soap11.xsd")));
  246.             }catch(Exception e){
  247.                 this.log.error("Integrazione.xsd, errore durante la costruzione del validatore xsd per Soap11: "+e.getMessage(),e);
  248.             }
  249.         }
  250.         
  251.         if(!this.validatoreXSD_soap12_map.containsKey(key)) {
  252.             try{
  253.                 XSDResourceResolver xsdResourceResolver_soap12 = new XSDResourceResolver();
  254.                 xsdResourceResolver_soap12.addResource("soapEnvelope12.xsd", UtilitiesIntegrazione.class.getResourceAsStream("/soapEnvelope12.xsd"));
  255.                 xsdResourceResolver_soap12.addResource("xml.xsd", UtilitiesIntegrazione.class.getResourceAsStream("/xml.xsd"));
  256.                 this.validatoreXSD_soap12_map.put(key, new ValidatoreXSD(messageFactory, this.log,xsdResourceResolver_soap12,UtilitiesIntegrazione.class.getResourceAsStream("/integrazione_soap12.xsd")));
  257.             }catch(Exception e){
  258.                 this.log.error("Integrazione.xsd, errore durante la costruzione del validatore xsd per Soap12: "+e.getMessage(),e);
  259.             }
  260.         }
  261.         
  262.     }
  263.     private void checkInitValidatoreXSD(OpenSPCoop2MessageFactory messageFactory) {
  264.         String key = messageFactory.getClass().getName();
  265.         if(!this.validatoreXSD_soap11_map.containsKey(key)) {
  266.             initValidatoreXSD(messageFactory);
  267.         }
  268.         if(!this.validatoreXSD_soap12_map.containsKey(key)) {
  269.             initValidatoreXSD(messageFactory);
  270.         }
  271.     }
  272.     private ValidatoreXSD getValidatoreXSD(boolean soap12, OpenSPCoop2MessageFactory messageFactory) {
  273.         
  274.         checkInitValidatoreXSD(messageFactory);
  275.         
  276.         String key = messageFactory.getClass().getName();
  277.         if(soap12) {
  278.             return this.validatoreXSD_soap12_map.get(key);
  279.         }
  280.         else {
  281.             return this.validatoreXSD_soap11_map.get(key);
  282.         }
  283.         
  284.     }
  285.         
  286.     public void readTransportProperties(Map<String, List<String>> prop,
  287.             HeaderIntegrazione integrazione) throws HeaderIntegrazioneException{
  288.         try{
  289.             if(prop!=null && integrazione!=null){
  290.                                 
  291.                 // Ricerca tra l'header del trasporto
  292.                 Iterator<String> keys = prop.keySet().iterator();
  293.                 while (keys.hasNext()) {
  294.                     String key = (String) keys.next();
  295.                     
  296.                     if(key!=null){
  297.                         
  298.                         for (MapKey<String> keywordIntegrazione : this.keywordsIntegrazione) {
  299.                             if(key.equalsIgnoreCase((String)this.keyValueIntegrazioneTrasporto.get(keywordIntegrazione))) {
  300.                                 
  301.                                 if(this.keyReadEnabled_HeaderIntegrazioneTrasporto.get(keywordIntegrazione)) {
  302.                                 
  303.                                     // Busta
  304.                                     if(CostantiPdD.HEADER_INTEGRAZIONE_TIPO_MITTENTE.equals(keywordIntegrazione)) {
  305.                                         integrazione.getBusta().setTipoMittente(TransportUtils.getFirstValue(prop,key));    
  306.                                     }
  307.                                     else if(CostantiPdD.HEADER_INTEGRAZIONE_MITTENTE.equals(keywordIntegrazione)) {
  308.                                         integrazione.getBusta().setMittente(TransportUtils.getFirstValue(prop,key));    
  309.                                     }
  310.                                     else if(CostantiPdD.HEADER_INTEGRAZIONE_TIPO_DESTINATARIO.equals(keywordIntegrazione)) {
  311.                                         integrazione.getBusta().setTipoDestinatario(TransportUtils.getFirstValue(prop,key));    
  312.                                     }
  313.                                     else if(CostantiPdD.HEADER_INTEGRAZIONE_DESTINATARIO.equals(keywordIntegrazione)) {
  314.                                         integrazione.getBusta().setDestinatario(TransportUtils.getFirstValue(prop,key));    
  315.                                     }
  316.                                     else if(CostantiPdD.HEADER_INTEGRAZIONE_TIPO_SERVIZIO.equals(keywordIntegrazione)) {
  317.                                         integrazione.getBusta().setTipoServizio(TransportUtils.getFirstValue(prop,key));    
  318.                                     }
  319.                                     else if(CostantiPdD.HEADER_INTEGRAZIONE_SERVIZIO.equals(keywordIntegrazione)) {
  320.                                         integrazione.getBusta().setServizio(TransportUtils.getFirstValue(prop,key));    
  321.                                     }
  322.                                     else if(CostantiPdD.HEADER_INTEGRAZIONE_VERSIONE_SERVIZIO.equals(keywordIntegrazione)) {
  323.                                         String v = TransportUtils.getFirstValue(prop,key);
  324.                                         try{
  325.                                             if(v!=null) {
  326.                                                 integrazione.getBusta().setVersioneServizio(Integer.parseInt(v));
  327.                                             }
  328.                                         }catch(Exception e){
  329.                                             throw new Exception("Formato versione ["+v+"] non corretto: "+e.getMessage(),e);
  330.                                         }
  331.                                     }
  332.                                     else if(CostantiPdD.HEADER_INTEGRAZIONE_AZIONE.equals(keywordIntegrazione)) {
  333.                                         integrazione.getBusta().setAzione(TransportUtils.getFirstValue(prop,key));  
  334.                                     }
  335.                                     else if(CostantiPdD.HEADER_INTEGRAZIONE_ID_MESSAGGIO.equals(keywordIntegrazione)) {
  336.                                         integrazione.getBusta().setID(TransportUtils.getFirstValue(prop,key));  
  337.                                     }
  338.                                     else if(CostantiPdD.HEADER_INTEGRAZIONE_RIFERIMENTO_MESSAGGIO.equals(keywordIntegrazione)) {
  339.                                         integrazione.getBusta().setRiferimentoMessaggio(TransportUtils.getFirstValue(prop,key));    
  340.                                     }
  341.                                     else if(CostantiPdD.HEADER_INTEGRAZIONE_COLLABORAZIONE.equals(keywordIntegrazione)) {
  342.                                         integrazione.getBusta().setIdCollaborazione(TransportUtils.getFirstValue(prop,key));    
  343.                                     }
  344.                                     
  345.                                     // id e servizio applicativo
  346.                                     else if(CostantiPdD.HEADER_INTEGRAZIONE_ID_APPLICATIVO.equals(keywordIntegrazione)) {
  347.                                         integrazione.setIdApplicativo(TransportUtils.getFirstValue(prop,key));  
  348.                                     }
  349.                                     else if(CostantiPdD.HEADER_INTEGRAZIONE_SERVIZIO_APPLICATIVO.equals(keywordIntegrazione)) {
  350.                                         integrazione.setServizioApplicativo(TransportUtils.getFirstValue(prop,key));    
  351.                                     }
  352.                                     else if(CostantiPdD.HEADER_INTEGRAZIONE_TIPO_MITTENTE_TOKEN.equals(keywordIntegrazione)) {
  353.                                         integrazione.setTipoSoggettoProprietarioApplicativoToken(TransportUtils.getFirstValue(prop,key));   
  354.                                     }
  355.                                     else if(CostantiPdD.HEADER_INTEGRAZIONE_MITTENTE_TOKEN.equals(keywordIntegrazione)) {
  356.                                         integrazione.setNomeSoggettoProprietarioApplicativoToken(TransportUtils.getFirstValue(prop,key));   
  357.                                     }
  358.                                     else if(CostantiPdD.HEADER_INTEGRAZIONE_SERVIZIO_APPLICATIVO_TOKEN.equals(keywordIntegrazione)) {
  359.                                         integrazione.setServizioApplicativoToken(TransportUtils.getFirstValue(prop,key));   
  360.                                     }
  361.                                     else if(CostantiPdD.HEADER_INTEGRAZIONE_ID_TRANSAZIONE.equals(keywordIntegrazione)) {
  362.                                         integrazione.setIdTransazione(TransportUtils.getFirstValue(prop,key));  
  363.                                     }
  364.                                 }
  365.                                 break;
  366.                             }
  367.                         }
  368.                         
  369.                     }
  370.                 }
  371.             }
  372.         }catch(Exception e){
  373.             throw new HeaderIntegrazioneException("UtilitiesIntegrazione, lettura dell'header non riuscita: "+e.getMessage(),e);
  374.         }
  375.     }
  376.     
  377.     public void readUrlProperties(Map<String, List<String>> prop,
  378.             HeaderIntegrazione integrazione) throws HeaderIntegrazioneException{
  379.         try{
  380.             if(prop!=null && integrazione!=null){
  381.             
  382.                 // Ricerca tra le proprieta' dell'url
  383.                 Iterator<String> keys = prop.keySet().iterator();
  384.                 while (keys.hasNext()) {
  385.                     String key = (String) keys.next();

  387.                     if(key!=null){
  388.                         
  389.                         for (MapKey<String> keywordIntegrazione : this.keywordsIntegrazione) {
  390.                             if(key.equalsIgnoreCase((String)this.keyValueIntegrazioneUrlBased.get(keywordIntegrazione))) {
  391.                                 
  392.                                 if(this.keyReadEnabled_HeaderIntegrazioneUrlBased.get(keywordIntegrazione)) {
  393.                                 
  394.                                     // Busta
  395.                                     if(CostantiPdD.HEADER_INTEGRAZIONE_TIPO_MITTENTE.equals(keywordIntegrazione)) {
  396.                                         integrazione.getBusta().setTipoMittente(TransportUtils.getFirstValue(prop,key));    
  397.                                     }
  398.                                     else if(CostantiPdD.HEADER_INTEGRAZIONE_MITTENTE.equals(keywordIntegrazione)) {
  399.                                         integrazione.getBusta().setMittente(TransportUtils.getFirstValue(prop,key));    
  400.                                     }
  401.                                     else if(CostantiPdD.HEADER_INTEGRAZIONE_TIPO_DESTINATARIO.equals(keywordIntegrazione)) {
  402.                                         integrazione.getBusta().setTipoDestinatario(TransportUtils.getFirstValue(prop,key));    
  403.                                     }
  404.                                     else if(CostantiPdD.HEADER_INTEGRAZIONE_DESTINATARIO.equals(keywordIntegrazione)) {
  405.                                         integrazione.getBusta().setDestinatario(TransportUtils.getFirstValue(prop,key));    
  406.                                     }
  407.                                     else if(CostantiPdD.HEADER_INTEGRAZIONE_TIPO_SERVIZIO.equals(keywordIntegrazione)) {
  408.                                         integrazione.getBusta().setTipoServizio(TransportUtils.getFirstValue(prop,key));    
  409.                                     }
  410.                                     else if(CostantiPdD.HEADER_INTEGRAZIONE_SERVIZIO.equals(keywordIntegrazione)) {
  411.                                         integrazione.getBusta().setServizio(TransportUtils.getFirstValue(prop,key));    
  412.                                     }
  413.                                     else if(CostantiPdD.HEADER_INTEGRAZIONE_VERSIONE_SERVIZIO.equals(keywordIntegrazione)) {
  414.                                         String v = TransportUtils.getFirstValue(prop,key);
  415.                                         try{
  416.                                             if(v!=null) {
  417.                                                 integrazione.getBusta().setVersioneServizio(Integer.parseInt(v));
  418.                                             }
  419.                                         }catch(Exception e){
  420.                                             throw new Exception("Formato versione ["+v+"] non corretto: "+e.getMessage(),e);
  421.                                         }
  422.                                     }
  423.                                     else if(CostantiPdD.HEADER_INTEGRAZIONE_AZIONE.equals(keywordIntegrazione)) {
  424.                                         integrazione.getBusta().setAzione(TransportUtils.getFirstValue(prop,key));  
  425.                                     }
  426.                                     else if(CostantiPdD.HEADER_INTEGRAZIONE_ID_MESSAGGIO.equals(keywordIntegrazione)) {
  427.                                         integrazione.getBusta().setID(TransportUtils.getFirstValue(prop,key));  
  428.                                     }
  429.                                     else if(CostantiPdD.HEADER_INTEGRAZIONE_RIFERIMENTO_MESSAGGIO.equals(keywordIntegrazione)) {
  430.                                         integrazione.getBusta().setRiferimentoMessaggio(TransportUtils.getFirstValue(prop,key));    
  431.                                     }
  432.                                     else if(CostantiPdD.HEADER_INTEGRAZIONE_COLLABORAZIONE.equals(keywordIntegrazione)) {
  433.                                         integrazione.getBusta().setIdCollaborazione(TransportUtils.getFirstValue(prop,key));    
  434.                                     }
  435.                                     
  436.                                     // id e servizio applicativo
  437.                                     else if(CostantiPdD.HEADER_INTEGRAZIONE_ID_APPLICATIVO.equals(keywordIntegrazione)) {
  438.                                         integrazione.setIdApplicativo(TransportUtils.getFirstValue(prop,key));  
  439.                                     }
  440.                                     else if(CostantiPdD.HEADER_INTEGRAZIONE_SERVIZIO_APPLICATIVO.equals(keywordIntegrazione)) {
  441.                                         integrazione.setServizioApplicativo(TransportUtils.getFirstValue(prop,key));    
  442.                                     }
  443.                                     else if(CostantiPdD.HEADER_INTEGRAZIONE_TIPO_MITTENTE_TOKEN.equals(keywordIntegrazione)) {
  444.                                         integrazione.setTipoSoggettoProprietarioApplicativoToken(TransportUtils.getFirstValue(prop,key));   
  445.                                     }
  446.                                     else if(CostantiPdD.HEADER_INTEGRAZIONE_MITTENTE_TOKEN.equals(keywordIntegrazione)) {
  447.                                         integrazione.setNomeSoggettoProprietarioApplicativoToken(TransportUtils.getFirstValue(prop,key));   
  448.                                     }
  449.                                     else if(CostantiPdD.HEADER_INTEGRAZIONE_SERVIZIO_APPLICATIVO_TOKEN.equals(keywordIntegrazione)) {
  450.                                         integrazione.setServizioApplicativoToken(TransportUtils.getFirstValue(prop,key));   
  451.                                     }
  452.                                     else if(CostantiPdD.HEADER_INTEGRAZIONE_ID_TRANSAZIONE.equals(keywordIntegrazione)) {
  453.                                         integrazione.setIdTransazione(TransportUtils.getFirstValue(prop,key));  
  454.                                     }
  455.                                 }
  456.                                 break;
  457.                             }
  458.                         }
  459.                         
  460.                     }
  461.                 }
  462.             }
  463.         }catch(Exception e){
  464.             throw new HeaderIntegrazioneException("UtilitiesIntegrazione, lettura dell'header non riuscita: "+e.getMessage(),e);
  465.         }
  466.     }
  467.     


  470.     public void setUrlProperties(HeaderIntegrazione integrazione,
  471.             Map<String, List<String>> properties,
  472.             Map<String, String> protocolInfos) throws HeaderIntegrazioneException{

  474.         try{
  475.             if(properties!=null && integrazione!=null){
  476.                 if(integrazione.getBusta()!=null){              
  477.                     if(integrazione.getBusta().getTipoMittente()!=null) {
  478.                         if(this.keySetEnabled_HeaderIntegrazioneUrlBased.get(CostantiPdD.HEADER_INTEGRAZIONE_TIPO_MITTENTE)) {
  479.                             TransportUtils.setParameter(properties,this.keyValueIntegrazioneUrlBased.get(CostantiPdD.HEADER_INTEGRAZIONE_TIPO_MITTENTE), integrazione.getBusta().getTipoMittente());
  480.                         }
  481.                     }
  482.                     if(integrazione.getBusta().getMittente()!=null) {
  483.                         if(this.keySetEnabled_HeaderIntegrazioneUrlBased.get(CostantiPdD.HEADER_INTEGRAZIONE_MITTENTE)) {
  484.                             TransportUtils.setParameter(properties,this.keyValueIntegrazioneUrlBased.get(CostantiPdD.HEADER_INTEGRAZIONE_MITTENTE), integrazione.getBusta().getMittente());
  485.                         }
  486.                     }
  487.                     if(integrazione.getBusta().getTipoDestinatario()!=null) {
  488.                         if(this.keySetEnabled_HeaderIntegrazioneUrlBased.get(CostantiPdD.HEADER_INTEGRAZIONE_TIPO_DESTINATARIO)) {
  489.                             TransportUtils.setParameter(properties,this.keyValueIntegrazioneUrlBased.get(CostantiPdD.HEADER_INTEGRAZIONE_TIPO_DESTINATARIO), integrazione.getBusta().getTipoDestinatario());
  490.                         }
  491.                     }
  492.                     if(integrazione.getBusta().getDestinatario()!=null) {
  493.                         if(this.keySetEnabled_HeaderIntegrazioneUrlBased.get(CostantiPdD.HEADER_INTEGRAZIONE_DESTINATARIO)) {
  494.                             TransportUtils.setParameter(properties,this.keyValueIntegrazioneUrlBased.get(CostantiPdD.HEADER_INTEGRAZIONE_DESTINATARIO), integrazione.getBusta().getDestinatario());
  495.                         }
  496.                     }
  497.                     if(integrazione.getBusta().getTipoServizio()!=null) {
  498.                         if(this.keySetEnabled_HeaderIntegrazioneUrlBased.get(CostantiPdD.HEADER_INTEGRAZIONE_TIPO_SERVIZIO)) {
  499.                             TransportUtils.setParameter(properties,this.keyValueIntegrazioneUrlBased.get(CostantiPdD.HEADER_INTEGRAZIONE_TIPO_SERVIZIO), integrazione.getBusta().getTipoServizio());
  500.                         }
  501.                     }
  502.                     if(integrazione.getBusta().getServizio()!=null) {
  503.                         if(this.keySetEnabled_HeaderIntegrazioneUrlBased.get(CostantiPdD.HEADER_INTEGRAZIONE_SERVIZIO)) {
  504.                             TransportUtils.setParameter(properties,this.keyValueIntegrazioneUrlBased.get(CostantiPdD.HEADER_INTEGRAZIONE_SERVIZIO), integrazione.getBusta().getServizio());
  505.                         }
  506.                     }
  507.                     if(integrazione.getBusta().getVersioneServizio()!=null) {
  508.                         if(this.keySetEnabled_HeaderIntegrazioneUrlBased.get(CostantiPdD.HEADER_INTEGRAZIONE_VERSIONE_SERVIZIO)) {
  509.                             TransportUtils.setParameter(properties,this.keyValueIntegrazioneUrlBased.get(CostantiPdD.HEADER_INTEGRAZIONE_VERSIONE_SERVIZIO), integrazione.getBusta().getVersioneServizio().intValue()+"");
  510.                         }
  511.                     }
  512.                     if(integrazione.getBusta().getAzione()!=null) {
  513.                         if(this.keySetEnabled_HeaderIntegrazioneUrlBased.get(CostantiPdD.HEADER_INTEGRAZIONE_AZIONE)) {
  514.                             TransportUtils.setParameter(properties,this.keyValueIntegrazioneUrlBased.get(CostantiPdD.HEADER_INTEGRAZIONE_AZIONE), integrazione.getBusta().getAzione());
  515.                         }
  516.                     }
  517.                     if(integrazione.getBusta().getID()!=null) {
  518.                         if(this.keySetEnabled_HeaderIntegrazioneUrlBased.get(CostantiPdD.HEADER_INTEGRAZIONE_ID_MESSAGGIO)) {
  519.                             TransportUtils.setParameter(properties,this.keyValueIntegrazioneUrlBased.get(CostantiPdD.HEADER_INTEGRAZIONE_ID_MESSAGGIO), integrazione.getBusta().getID());
  520.                         }
  521.                     }
  522.                     if(integrazione.getBusta().getRiferimentoMessaggio()!=null) {
  523.                         if(this.keySetEnabled_HeaderIntegrazioneUrlBased.get(CostantiPdD.HEADER_INTEGRAZIONE_RIFERIMENTO_MESSAGGIO)) {
  524.                             TransportUtils.setParameter(properties,this.keyValueIntegrazioneUrlBased.get(CostantiPdD.HEADER_INTEGRAZIONE_RIFERIMENTO_MESSAGGIO), integrazione.getBusta().getRiferimentoMessaggio());
  525.                         }
  526.                     }
  527.                     if(integrazione.getBusta().getIdCollaborazione()!=null) {
  528.                         if(this.keySetEnabled_HeaderIntegrazioneUrlBased.get(CostantiPdD.HEADER_INTEGRAZIONE_COLLABORAZIONE)) {
  529.                             TransportUtils.setParameter(properties,this.keyValueIntegrazioneUrlBased.get(CostantiPdD.HEADER_INTEGRAZIONE_COLLABORAZIONE), integrazione.getBusta().getIdCollaborazione());
  530.                         }
  531.                     }
  532.                 }
  533.                 if(integrazione.getIdApplicativo()!=null) {
  534.                     if(this.keySetEnabled_HeaderIntegrazioneUrlBased.get(CostantiPdD.HEADER_INTEGRAZIONE_ID_APPLICATIVO)) {
  535.                         TransportUtils.setParameter(properties,this.keyValueIntegrazioneUrlBased.get(CostantiPdD.HEADER_INTEGRAZIONE_ID_APPLICATIVO), integrazione.getIdApplicativo());
  536.                     }
  537.                 }
  538.                 if(integrazione.getServizioApplicativo()!=null) {
  539.                     if(this.keySetEnabled_HeaderIntegrazioneUrlBased.get(CostantiPdD.HEADER_INTEGRAZIONE_SERVIZIO_APPLICATIVO)) {
  540.                         TransportUtils.setParameter(properties,this.keyValueIntegrazioneUrlBased.get(CostantiPdD.HEADER_INTEGRAZIONE_SERVIZIO_APPLICATIVO), integrazione.getServizioApplicativo());
  541.                     }
  542.                 }
  543.                 if(integrazione.getTipoSoggettoProprietarioApplicativoToken()!=null) {
  544.                     if(this.keySetEnabled_HeaderIntegrazioneUrlBased.get(CostantiPdD.HEADER_INTEGRAZIONE_TIPO_MITTENTE_TOKEN)) {
  545.                         TransportUtils.setParameter(properties,this.keyValueIntegrazioneUrlBased.get(CostantiPdD.HEADER_INTEGRAZIONE_TIPO_MITTENTE_TOKEN), integrazione.getTipoSoggettoProprietarioApplicativoToken());
  546.                     }
  547.                 }
  548.                 if(integrazione.getNomeSoggettoProprietarioApplicativoToken()!=null) {
  549.                     if(this.keySetEnabled_HeaderIntegrazioneUrlBased.get(CostantiPdD.HEADER_INTEGRAZIONE_MITTENTE_TOKEN)) {
  550.                         TransportUtils.setParameter(properties,this.keyValueIntegrazioneUrlBased.get(CostantiPdD.HEADER_INTEGRAZIONE_MITTENTE_TOKEN), integrazione.getNomeSoggettoProprietarioApplicativoToken());
  551.                     }
  552.                 }
  553.                 if(integrazione.getServizioApplicativoToken()!=null) {
  554.                     if(this.keySetEnabled_HeaderIntegrazioneUrlBased.get(CostantiPdD.HEADER_INTEGRAZIONE_SERVIZIO_APPLICATIVO_TOKEN)) {
  555.                         TransportUtils.setParameter(properties,this.keyValueIntegrazioneUrlBased.get(CostantiPdD.HEADER_INTEGRAZIONE_SERVIZIO_APPLICATIVO_TOKEN), integrazione.getServizioApplicativoToken());
  556.                     }
  557.                 }
  558.                 if(integrazione.getIdTransazione()!=null) {
  559.                     if(this.keySetEnabled_HeaderIntegrazioneUrlBased.get(CostantiPdD.HEADER_INTEGRAZIONE_ID_TRANSAZIONE)) {
  560.                         TransportUtils.setParameter(properties,this.keyValueIntegrazioneUrlBased.get(CostantiPdD.HEADER_INTEGRAZIONE_ID_TRANSAZIONE), integrazione.getIdTransazione());
  561.                     }
  562.                 }
  563.             }
  564.             if(properties!=null){
  565. //              properties.put(CostantiPdD.URL_BASED_PDD,URLEncoder.encode(this.openspcoopProperties.getHttpServer(),"UTF-8"));
  566. //              if(this.openspcoopProperties.getHttpXPdDDetails()!=null && !"".equals(this.openspcoopProperties.getHttpXPdDDetails())){
  567. //                  properties.put(CostantiPdD.URL_BASED_PDD_DETAILS,URLEncoder.encode(this.openspcoopProperties.getHttpXPdDDetails(),"UTF-8"));
  568. //              }
  569.                 // Non deve essere effettuato a questo livello l'URLEncoder altrimenti si ottiene una doppia codifica, essendo poi fatta anche per tutti i valori in ConnettoreUtils.
  570.                 
  571.                 if(this.keySetEnabled_HeaderIntegrazioneUrlBased.get(CostantiPdD.HEADER_INTEGRAZIONE_INFO)) {
  572.                     TransportUtils.setParameter(properties,CostantiPdD.URL_BASED_PDD,this.openspcoopProperties.getHttpServer());
  573.                     if(this.openspcoopProperties.getHttpXPdDDetails()!=null && !"".equals(this.openspcoopProperties.getHttpXPdDDetails())){
  574.                         TransportUtils.setParameter(properties,CostantiPdD.URL_BASED_PDD_DETAILS,this.openspcoopProperties.getHttpXPdDDetails());
  575.                     }
  576.                 }

  578.                 if(this.keySetEnabled_HeaderIntegrazioneUrlBased.get(CostantiPdD.HEADER_INTEGRAZIONE_PROTOCOL_INFO)) {
  579.                     // protocol info
  580.                     if(protocolInfos!=null && protocolInfos.size()>0){
  581.                         
  582.                         String prefixProtocolInfo = this.keyValueIntegrazioneUrlBased.get(CostantiPdD.HEADER_INTEGRAZIONE_PROTOCOL_INFO);
  583.                         
  584.                         Iterator<String> itProtocolInfos = protocolInfos.keySet().iterator();
  585.                         while (itProtocolInfos.hasNext()) {
  586.                             String name = (String) itProtocolInfos.next();
  587.                             String value = protocolInfos.get(name);
  588.                             String nameWithPrefix = (prefixProtocolInfo!=null) ? prefixProtocolInfo.trim()+name : name;
  589.                             TransportUtils.setParameter(properties,nameWithPrefix,value);
  590.                         }
  591.                     }
  592.                 }
  593.             }
  594.             
  595.         }catch(Exception e){
  596.             throw new HeaderIntegrazioneException("UtilitiesIntegrazione, creazione delle proprieta' dell'header non riuscita: "+e.getMessage(),e);
  597.         }
  598.     }
  599.     
  600.     public void setSecurityHeaders(ServiceBinding serviceBinding, RequestInfo requestInfo, Map<String, List<String>> properties, OpenSPCoop2MessageProperties forwardHeader) throws HeaderIntegrazioneException{
  601.         
  602.         try {
  603.             List<Proprieta> proprieta = null;
  604.             if(requestInfo!=null && requestInfo.getProtocolContext()!=null && requestInfo.getProtocolContext().getInterfaceName()!=null) {
  605.                 if(this.portaDelegata) {
  606.                     IDPortaDelegata idPD = new IDPortaDelegata();
  607.                     idPD.setNome(requestInfo.getProtocolContext().getInterfaceName());
  608.                     PortaDelegata pd = ConfigurazionePdDManager.getInstance(null).getPortaDelegataSafeMethod(idPD, requestInfo);
  609.                     if(pd!=null) {
  610.                         proprieta = pd.getProprietaList();
  611.                     }
  612.                 }
  613.                 else {
  614.                     IDPortaApplicativa idPA = new IDPortaApplicativa();
  615.                     idPA.setNome(requestInfo.getProtocolContext().getInterfaceName());
  616.                     PortaApplicativa pa = ConfigurazionePdDManager.getInstance(null).getPortaApplicativaSafeMethod(idPA, requestInfo);
  617.                     if(pa!=null) {
  618.                         proprieta = pa.getProprietaList();
  619.                     }
  620.                 }
  621.             }
  622.             
  623.             boolean enabled = false;
  624.             if(this.portaDelegata) {
  625.                 if(ServiceBinding.REST.equals(serviceBinding)) {
  626.                     enabled = this.openspcoopProperties.isRESTServices_inoltroBuste_response_securityHeaders();
  627.                 }
  628.                 else {
  629.                     enabled = this.openspcoopProperties.isSOAPServices_inoltroBuste_response_securityHeaders();
  630.                 }
  631.             }
  632.             else {
  633.                 if(ServiceBinding.REST.equals(serviceBinding)) {
  634.                     enabled = this.openspcoopProperties.isRESTServices_consegnaContenutiApplicativi_response_securityHeaders();
  635.                 }
  636.                 else {
  637.                     enabled = this.openspcoopProperties.isSOAPServices_consegnaContenutiApplicativi_response_securityHeaders();
  638.                 }
  639.             }
  640.             enabled = CostantiProprieta.isSecurityHeadersEnabled(proprieta, enabled);
  641.             
  642.             if(enabled) {
  643.                 
  644.                 Properties pDefault = null;
  645.                 if(this.portaDelegata) {
  646.                     if(ServiceBinding.REST.equals(serviceBinding)) {
  647.                         pDefault = this.openspcoopProperties.getRESTServices_inoltroBuste_response_securityHeaders();
  648.                     }
  649.                     else {
  650.                         pDefault = this.openspcoopProperties.getSOAPServices_inoltroBuste_response_securityHeaders();
  651.                     }
  652.                 }
  653.                 else {
  654.                     if(ServiceBinding.REST.equals(serviceBinding)) {
  655.                         pDefault = this.openspcoopProperties.getRESTServices_consegnaContenutiApplicativi_response_securityHeaders();
  656.                     }
  657.                     else {
  658.                         pDefault = this.openspcoopProperties.getSOAPServices_consegnaContenutiApplicativi_response_securityHeaders();
  659.                     }
  660.                 }
  661.                 
  662.                 Map<String, String> securityHeaders = CostantiProprieta.getSecurityHeaders(proprieta, pDefault);
  663.                 if(securityHeaders!=null && !securityHeaders.isEmpty()) {
  664.                     
  665.                     boolean headerCachePresenteRispostaBackend = false;
  666.                     // Gli header per la cache vengono gestiti in blocco
  667.                     for (String hdrName : securityHeaders.keySet()) {
  668.                         if(HttpConstants.isCacheStatusHeader(hdrName)) {
  669.                             if( (TransportUtils.containsKey(properties, hdrName)) 
  670.                                     ||
  671.                                     (forwardHeader!=null && forwardHeader.containsKey(hdrName))
  672.                                 ) { 
  673.                                 headerCachePresenteRispostaBackend = true;  
  674.                                 break;
  675.                             }
  676.                         }
  677.                     }
  678.                     
  679.                     for (String hdrName : securityHeaders.keySet()) {
  680.                         
  681.                         if(HttpConstants.isCacheStatusHeader(hdrName) && headerCachePresenteRispostaBackend) {
  682.                             continue;
  683.                         }
  684.                         
  685.                         if( (!TransportUtils.containsKey(properties, hdrName)) 
  686.                                 && 
  687.                                 (forwardHeader==null || !forwardHeader.containsKey(hdrName))
  688.                             ) { // altrimenti è stato definito dal backend e lascio quello
  689.                             String hdrValue = securityHeaders.get(hdrName);
  690.                             if(hdrValue!=null) {
  691.                                 TransportUtils.setHeader(properties, hdrName, hdrValue);
  692.                             }
  693.                         }
  694.                     }
  695.                 }
  696.                 
  697.             }
  698.             
  699.         }catch(Exception e) {
  700.             throw new HeaderIntegrazioneException("UtilitiesIntegrazione, creazione securityHeaders non riuscita: "+e.getMessage(),e);
  701.         }
  702.         
  703.     }
  704.     
  705.     public void setInfoProductTransportProperties(Map<String, List<String>> properties) throws HeaderIntegrazioneException{
  706.         setTransportProperties(null, properties, null);
  707.     }
  708.     public void setTransportProperties(HeaderIntegrazione integrazione,
  709.             Map<String, List<String>> properties,
  710.             Map<String, String> protocolInfos) throws HeaderIntegrazioneException{

  712.         try{
  713.             if(properties!=null && integrazione!=null){
  714.                 if(integrazione.getBusta()!=null){
  715.                     if(integrazione.getBusta().getTipoMittente()!=null) {
  716.                         if(this.keySetEnabled_HeaderIntegrazioneTrasporto.get(CostantiPdD.HEADER_INTEGRAZIONE_TIPO_MITTENTE)) {
  717.                             TransportUtils.setHeader(properties,this.keyValueIntegrazioneTrasporto.get(CostantiPdD.HEADER_INTEGRAZIONE_TIPO_MITTENTE), integrazione.getBusta().getTipoMittente());
  718.                         }
  719.                     }
  720.                     if(integrazione.getBusta().getMittente()!=null) {
  721.                         if(this.keySetEnabled_HeaderIntegrazioneTrasporto.get(CostantiPdD.HEADER_INTEGRAZIONE_MITTENTE)) {
  722.                             TransportUtils.setHeader(properties,this.keyValueIntegrazioneTrasporto.get(CostantiPdD.HEADER_INTEGRAZIONE_MITTENTE), integrazione.getBusta().getMittente());
  723.                         }
  724.                     }
  725.                     if(integrazione.getBusta().getTipoDestinatario()!=null) {
  726.                         if(this.keySetEnabled_HeaderIntegrazioneTrasporto.get(CostantiPdD.HEADER_INTEGRAZIONE_TIPO_DESTINATARIO)) {
  727.                             TransportUtils.setHeader(properties,this.keyValueIntegrazioneTrasporto.get(CostantiPdD.HEADER_INTEGRAZIONE_TIPO_DESTINATARIO), integrazione.getBusta().getTipoDestinatario());
  728.                         }
  729.                     }
  730.                     if(integrazione.getBusta().getDestinatario()!=null) {
  731.                         if(this.keySetEnabled_HeaderIntegrazioneTrasporto.get(CostantiPdD.HEADER_INTEGRAZIONE_DESTINATARIO)) {
  732.                             TransportUtils.setHeader(properties,this.keyValueIntegrazioneTrasporto.get(CostantiPdD.HEADER_INTEGRAZIONE_DESTINATARIO), integrazione.getBusta().getDestinatario());
  733.                         }
  734.                     }
  735.                     if(integrazione.getBusta().getTipoServizio()!=null) {
  736.                         if(this.keySetEnabled_HeaderIntegrazioneTrasporto.get(CostantiPdD.HEADER_INTEGRAZIONE_TIPO_SERVIZIO)) {
  737.                             TransportUtils.setHeader(properties,this.keyValueIntegrazioneTrasporto.get(CostantiPdD.HEADER_INTEGRAZIONE_TIPO_SERVIZIO), integrazione.getBusta().getTipoServizio());
  738.                         }
  739.                     }
  740.                     if(integrazione.getBusta().getServizio()!=null) {
  741.                         if(this.keySetEnabled_HeaderIntegrazioneTrasporto.get(CostantiPdD.HEADER_INTEGRAZIONE_SERVIZIO)) {
  742.                             TransportUtils.setHeader(properties,this.keyValueIntegrazioneTrasporto.get(CostantiPdD.HEADER_INTEGRAZIONE_SERVIZIO), integrazione.getBusta().getServizio());
  743.                         }
  744.                     }
  745.                     if(integrazione.getBusta().getVersioneServizio()!=null) {
  746.                         if(this.keySetEnabled_HeaderIntegrazioneTrasporto.get(CostantiPdD.HEADER_INTEGRAZIONE_VERSIONE_SERVIZIO)) {
  747.                             TransportUtils.setHeader(properties,this.keyValueIntegrazioneTrasporto.get(CostantiPdD.HEADER_INTEGRAZIONE_VERSIONE_SERVIZIO), integrazione.getBusta().getVersioneServizio().intValue()+"");
  748.                         }
  749.                     }
  750.                     if(integrazione.getBusta().getAzione()!=null) {
  751.                         if(this.keySetEnabled_HeaderIntegrazioneTrasporto.get(CostantiPdD.HEADER_INTEGRAZIONE_AZIONE)) {
  752.                             TransportUtils.setHeader(properties,this.keyValueIntegrazioneTrasporto.get(CostantiPdD.HEADER_INTEGRAZIONE_AZIONE), integrazione.getBusta().getAzione());
  753.                         }
  754.                     }
  755.                     if(integrazione.getBusta().getID()!=null) {
  756.                         if(this.keySetEnabled_HeaderIntegrazioneTrasporto.get(CostantiPdD.HEADER_INTEGRAZIONE_ID_MESSAGGIO)) {
  757.                             TransportUtils.setHeader(properties,this.keyValueIntegrazioneTrasporto.get(CostantiPdD.HEADER_INTEGRAZIONE_ID_MESSAGGIO), integrazione.getBusta().getID());
  758.                         }
  759.                     }
  760.                     if(integrazione.getBusta().getRiferimentoMessaggio()!=null) {
  761.                         if(this.keySetEnabled_HeaderIntegrazioneTrasporto.get(CostantiPdD.HEADER_INTEGRAZIONE_RIFERIMENTO_MESSAGGIO)) {
  762.                             TransportUtils.setHeader(properties,this.keyValueIntegrazioneTrasporto.get(CostantiPdD.HEADER_INTEGRAZIONE_RIFERIMENTO_MESSAGGIO), integrazione.getBusta().getRiferimentoMessaggio());
  763.                         }
  764.                     }
  765.                     if(integrazione.getBusta().getIdCollaborazione()!=null) {
  766.                         if(this.keySetEnabled_HeaderIntegrazioneTrasporto.get(CostantiPdD.HEADER_INTEGRAZIONE_COLLABORAZIONE)) {
  767.                             TransportUtils.setHeader(properties,this.keyValueIntegrazioneTrasporto.get(CostantiPdD.HEADER_INTEGRAZIONE_COLLABORAZIONE), integrazione.getBusta().getIdCollaborazione());
  768.                         }
  769.                     }
  770.                 }
  771.                 if(integrazione.getIdApplicativo()!=null) {
  772.                     if(this.keySetEnabled_HeaderIntegrazioneTrasporto.get(CostantiPdD.HEADER_INTEGRAZIONE_ID_APPLICATIVO)) {
  773.                         TransportUtils.setHeader(properties,this.keyValueIntegrazioneTrasporto.get(CostantiPdD.HEADER_INTEGRAZIONE_ID_APPLICATIVO), integrazione.getIdApplicativo());
  774.                     }
  775.                 }
  776.                 if(integrazione.getServizioApplicativo()!=null) {
  777.                     if(this.keySetEnabled_HeaderIntegrazioneTrasporto.get(CostantiPdD.HEADER_INTEGRAZIONE_SERVIZIO_APPLICATIVO)) {
  778.                         TransportUtils.setHeader(properties,this.keyValueIntegrazioneTrasporto.get(CostantiPdD.HEADER_INTEGRAZIONE_SERVIZIO_APPLICATIVO), integrazione.getServizioApplicativo());
  779.                     }
  780.                 }
  781.                 if(integrazione.getTipoSoggettoProprietarioApplicativoToken()!=null) {
  782.                     if(this.keySetEnabled_HeaderIntegrazioneTrasporto.get(CostantiPdD.HEADER_INTEGRAZIONE_TIPO_MITTENTE_TOKEN)) {
  783.                         TransportUtils.setParameter(properties,this.keyValueIntegrazioneTrasporto.get(CostantiPdD.HEADER_INTEGRAZIONE_TIPO_MITTENTE_TOKEN), integrazione.getTipoSoggettoProprietarioApplicativoToken());
  784.                     }
  785.                 }
  786.                 if(integrazione.getNomeSoggettoProprietarioApplicativoToken()!=null) {
  787.                     if(this.keySetEnabled_HeaderIntegrazioneTrasporto.get(CostantiPdD.HEADER_INTEGRAZIONE_MITTENTE_TOKEN)) {
  788.                         TransportUtils.setParameter(properties,this.keyValueIntegrazioneTrasporto.get(CostantiPdD.HEADER_INTEGRAZIONE_MITTENTE_TOKEN), integrazione.getNomeSoggettoProprietarioApplicativoToken());
  789.                     }
  790.                 }
  791.                 if(integrazione.getServizioApplicativoToken()!=null) {
  792.                     if(this.keySetEnabled_HeaderIntegrazioneTrasporto.get(CostantiPdD.HEADER_INTEGRAZIONE_SERVIZIO_APPLICATIVO_TOKEN)) {
  793.                         TransportUtils.setParameter(properties,this.keyValueIntegrazioneTrasporto.get(CostantiPdD.HEADER_INTEGRAZIONE_SERVIZIO_APPLICATIVO_TOKEN), integrazione.getServizioApplicativoToken());
  794.                     }
  795.                 }
  796.                 if(integrazione.getIdTransazione()!=null) {
  797.                     if(this.keySetEnabled_HeaderIntegrazioneTrasporto.get(CostantiPdD.HEADER_INTEGRAZIONE_ID_TRANSAZIONE)) {
  798.                         TransportUtils.setHeader(properties,this.keyValueIntegrazioneTrasporto.get(CostantiPdD.HEADER_INTEGRAZIONE_ID_TRANSAZIONE), integrazione.getIdTransazione());
  799.                     }
  800.                 }
  801.             }
  802.             if(properties!=null){
  803.                 
  804.                 boolean infoProduct = this.keySetEnabled_HeaderIntegrazioneTrasporto.get(CostantiPdD.HEADER_INTEGRAZIONE_INFO);
  805.                 if(infoProduct) {
  806.                     if(properties.containsKey(CostantiPdD.HEADER_HTTP_X_PDD)==false) {
  807.                         TransportUtils.setHeader(properties,CostantiPdD.HEADER_HTTP_X_PDD,this.openspcoopProperties.getHttpServer());
  808.                     }
  809.                     if(this.openspcoopProperties.getHttpXPdDDetails()!=null && !"".equals(this.openspcoopProperties.getHttpXPdDDetails())){
  810.                         if(properties.containsKey(CostantiPdD.HEADER_HTTP_X_PDD_DETAILS)==false) {
  811.                             TransportUtils.setHeader(properties,CostantiPdD.HEADER_HTTP_X_PDD_DETAILS,this.openspcoopProperties.getHttpXPdDDetails());
  812.                         }
  813.                     }
  814.                 }
  815.                 
  816.                 boolean userAgent = this.keySetEnabled_HeaderIntegrazioneTrasporto.get(CostantiPdD.HEADER_INTEGRAZIONE_USER_AGENT);
  817.                 if(userAgent) {
  818.                     if(this.request) {
  819.                         if(properties.containsKey(HttpConstants.USER_AGENT)==false) {
  820.                             TransportUtils.setHeader(properties,HttpConstants.USER_AGENT,this.openspcoopProperties.getHttpUserAgent());
  821.                         }
  822.                     }
  823.                     else {
  824.                         if(properties.containsKey(HttpConstants.SERVER)==false) {
  825.                             TransportUtils.setHeader(properties,HttpConstants.SERVER,this.openspcoopProperties.getHttpUserAgent());
  826.                         }
  827.                     }
  828.                 }
  829.                 
  830.                 if(this.keySetEnabled_HeaderIntegrazioneTrasporto.get(CostantiPdD.HEADER_INTEGRAZIONE_PROTOCOL_INFO)) {
  831.                     if(protocolInfos!=null && protocolInfos.size()>0){
  832.                         
  833.                         String prefixProtocolInfo = this.keyValueIntegrazioneTrasporto.get(CostantiPdD.HEADER_INTEGRAZIONE_PROTOCOL_INFO);
  834.                         
  835.                         Iterator<String> itProtocolInfos = protocolInfos.keySet().iterator();
  836.                         while (itProtocolInfos.hasNext()) {
  837.                             String name = (String) itProtocolInfos.next();
  838.                             String value = protocolInfos.get(name);
  839.                             String nameWithPrefix = (prefixProtocolInfo!=null) ? prefixProtocolInfo.trim()+name : name;
  840.                             TransportUtils.setHeader(properties,nameWithPrefix,value);
  841.                         }
  842.                     }
  843.                 }
  844.                 
  845.             }
  846.         }catch(Exception e){
  847.             throw new HeaderIntegrazioneException("UtilitiesIntegrazione, creazione delle proprieta' dell'header non riuscita: "+e.getMessage(),e);
  848.         }
  849.     }
  850.     
  851.     

  853.     public void readHeader(OpenSPCoop2SoapMessage message,HeaderIntegrazione integrazione,
  854.             String actorIntegrazione) throws HeaderIntegrazioneException{
  855.         
  856.         
  857.         try{            
  858.             if(actorIntegrazione==null)
  859.                 throw new Exception("Actor non definito");
  860.             SOAPHeader header = message.getSOAPHeader();
  861.             if(header==null){
  862.                 OpenSPCoop2Logger.getLoggerOpenSPCoopCore().debug("SOAPHeader non presente");
  863.                 return;
  864.             }
  865.             SOAPHeaderElement headerElement = null;
  866.             java.util.Iterator<?> it = header.examineAllHeaderElements();
  867.             while( it.hasNext()  ){
  868.                 // Test Header Element
  869.                 headerElement = (SOAPHeaderElement) it.next();
  870.                 //Controllo Actor
  871.                 String actorCheck = SoapUtils.getSoapActor(headerElement, message.getMessageType());
  872.                 if( actorIntegrazione.equals(actorCheck) ){
  873.                     break;
  874.                 }else{
  875.                     headerElement = null;
  876.                 }
  877.             }
  878.             if(headerElement==null){
  879.                 OpenSPCoop2Logger.getLoggerOpenSPCoopCore().debug("Header di integrazione non presente");
  880.                 return;
  881.             }
  882.             
  883.             // validazione XSD
  884.             if(MessageType.SOAP_11.equals(message.getMessageType())){
  885.                 ValidatoreXSD validatoreXSD_soap11 = getValidatoreXSD(false, message.getFactory());
  886.                 if(validatoreXSD_soap11==null)
  887.                     throw new Exception("Validatore XSD (Soap11) non istanziato");
  888.                 validatoreXSD_soap11.valida(new java.io.ByteArrayInputStream(message.getAsByte(headerElement, false)));
  889.             }
  890.             else if(MessageType.SOAP_12.equals(message.getMessageType())){
  891.                 ValidatoreXSD validatoreXSD_soap12 = getValidatoreXSD(false, message.getFactory());
  892.                 if(validatoreXSD_soap12==null)
  893.                     throw new Exception("Validatore XSD (Soap12) non istanziato");
  894.                 validatoreXSD_soap12.valida(new java.io.ByteArrayInputStream(message.getAsByte(headerElement, false)));
  895.             }
  896.             else{
  897.                 throw MessageNotSupportedException.newMessageNotSupportedException(message.getMessageType());
  898.             }

  900.             
  901.             // Ricerca tra gli attributi dell'header SOAP
  902.             String tipoMittente = null;
  903.             try{
  904.                 if(this.keyReadEnabled_HeaderIntegrazioneSoap.get(CostantiPdD.HEADER_INTEGRAZIONE_TIPO_MITTENTE)) {
  905.                     tipoMittente = headerElement.getAttribute((String)this.keyValueIntegrazioneSoap.get(CostantiPdD.HEADER_INTEGRAZIONE_TIPO_MITTENTE));
  906.                 }
  907.             }catch(Exception e){}
  908.             if(tipoMittente!=null && tipoMittente.compareTo("")!=0)
  909.                 integrazione.getBusta().setTipoMittente(tipoMittente);
  910.             
  911.             String mittente = null;
  912.             try{
  913.                 if(this.keyReadEnabled_HeaderIntegrazioneSoap.get(CostantiPdD.HEADER_INTEGRAZIONE_MITTENTE)) {
  914.                     mittente = headerElement.getAttribute((String)this.keyValueIntegrazioneSoap.get(CostantiPdD.HEADER_INTEGRAZIONE_MITTENTE));
  915.                 }
  916.             }catch(Exception e){}
  917.             if(mittente!=null && mittente.compareTo("")!=0)
  918.                 integrazione.getBusta().setMittente(mittente);
  919.             
  920.             String tipoDestinatario = null;
  921.             try{
  922.                 if(this.keyReadEnabled_HeaderIntegrazioneSoap.get(CostantiPdD.HEADER_INTEGRAZIONE_TIPO_DESTINATARIO)) {
  923.                     tipoDestinatario = headerElement.getAttribute((String)this.keyValueIntegrazioneSoap.get(CostantiPdD.HEADER_INTEGRAZIONE_TIPO_DESTINATARIO));
  924.                 }
  925.             }catch(Exception e){}
  926.             if(tipoDestinatario!=null && tipoDestinatario.compareTo("")!=0)
  927.                 integrazione.getBusta().setTipoDestinatario(tipoDestinatario);
  928.             
  929.             String destinatario = null;
  930.             try{
  931.                 if(this.keyReadEnabled_HeaderIntegrazioneSoap.get(CostantiPdD.HEADER_INTEGRAZIONE_DESTINATARIO)) {
  932.                     destinatario = headerElement.getAttribute((String)this.keyValueIntegrazioneSoap.get(CostantiPdD.HEADER_INTEGRAZIONE_DESTINATARIO));
  933.                 }
  934.             }catch(Exception e){}
  935.             if(destinatario!=null && destinatario.compareTo("")!=0)
  936.                 integrazione.getBusta().setDestinatario(destinatario);

  938.             String tipoServizio = null;
  939.             try{
  940.                 if(this.keyReadEnabled_HeaderIntegrazioneSoap.get(CostantiPdD.HEADER_INTEGRAZIONE_TIPO_SERVIZIO)) {
  941.                     tipoServizio = headerElement.getAttribute((String)this.keyValueIntegrazioneSoap.get(CostantiPdD.HEADER_INTEGRAZIONE_TIPO_SERVIZIO));
  942.                 }
  943.             }catch(Exception e){}
  944.             if(tipoServizio!=null && tipoServizio.compareTo("")!=0)
  945.                 integrazione.getBusta().setTipoServizio(tipoServizio);
  946.             
  947.             String servizio = null;
  948.             try{
  949.                 if(this.keyReadEnabled_HeaderIntegrazioneSoap.get(CostantiPdD.HEADER_INTEGRAZIONE_SERVIZIO)) {
  950.                     servizio = headerElement.getAttribute((String)this.keyValueIntegrazioneSoap.get(CostantiPdD.HEADER_INTEGRAZIONE_SERVIZIO));
  951.                 }
  952.             }catch(Exception e){}
  953.             if(servizio!=null && servizio.compareTo("")!=0)
  954.                 integrazione.getBusta().setServizio(servizio);
  955.             
  956.             String versioneServizio = null;
  957.             try{
  958.                 if(this.keyReadEnabled_HeaderIntegrazioneSoap.get(CostantiPdD.HEADER_INTEGRAZIONE_VERSIONE_SERVIZIO)) {
  959.                     versioneServizio = headerElement.getAttribute((String)this.keyValueIntegrazioneSoap.get(CostantiPdD.HEADER_INTEGRAZIONE_VERSIONE_SERVIZIO));
  960.                 }
  961.             }catch(Exception e){}
  962.             if(versioneServizio!=null && versioneServizio.compareTo("")!=0){
  963.                 try{
  964.                     integrazione.getBusta().setVersioneServizio(Integer.parseInt(versioneServizio));
  965.                 }catch(Exception e){
  966.                     throw new Exception("Formato versione ["+versioneServizio+"] non corretto: "+e.getMessage(),e);
  967.                 }
  968.             }

  970.             String azione= null;
  971.             try{
  972.                 if(this.keyReadEnabled_HeaderIntegrazioneSoap.get(CostantiPdD.HEADER_INTEGRAZIONE_AZIONE)) {
  973.                     azione= headerElement.getAttribute((String)this.keyValueIntegrazioneSoap.get(CostantiPdD.HEADER_INTEGRAZIONE_AZIONE));
  974.                 }
  975.             }catch(Exception e){}
  976.             if(azione!=null && azione.compareTo("")!=0)
  977.                 integrazione.getBusta().setAzione(azione);

  979.             String idBusta = null;
  980.             try{
  981.                 if(this.keyReadEnabled_HeaderIntegrazioneSoap.get(CostantiPdD.HEADER_INTEGRAZIONE_ID_MESSAGGIO)) {
  982.                     idBusta = headerElement.getAttribute((String)this.keyValueIntegrazioneSoap.get(CostantiPdD.HEADER_INTEGRAZIONE_ID_MESSAGGIO));
  983.                 }
  984.             }catch(Exception e){}
  985.             if(idBusta!=null && idBusta.compareTo("")!=0)
  986.                 integrazione.getBusta().setID(idBusta);

  988.             String riferimentoMessaggio = null;
  989.             try{
  990.                 if(this.keyReadEnabled_HeaderIntegrazioneSoap.get(CostantiPdD.HEADER_INTEGRAZIONE_RIFERIMENTO_MESSAGGIO)) {
  991.                     riferimentoMessaggio = headerElement.getAttribute((String)this.keyValueIntegrazioneSoap.get(CostantiPdD.HEADER_INTEGRAZIONE_RIFERIMENTO_MESSAGGIO));
  992.                 }
  993.             }catch(Exception e){}
  994.             if(riferimentoMessaggio!=null && riferimentoMessaggio.compareTo("")!=0)
  995.                 integrazione.getBusta().setRiferimentoMessaggio(riferimentoMessaggio);

  997.             String collaborazione = null;
  998.             try{
  999.                 if(this.keyReadEnabled_HeaderIntegrazioneSoap.get(CostantiPdD.HEADER_INTEGRAZIONE_COLLABORAZIONE)) {
  1000.                     collaborazione = headerElement.getAttribute((String)this.keyValueIntegrazioneSoap.get(CostantiPdD.HEADER_INTEGRAZIONE_COLLABORAZIONE));
  1001.                 }
  1002.             }catch(Exception e){}
  1003.             if(collaborazione!=null && collaborazione.compareTo("")!=0)
  1004.                 integrazione.getBusta().setIdCollaborazione(collaborazione);

  1006.             String idApplicativo = null;
  1007.             try{
  1008.                 if(this.keyReadEnabled_HeaderIntegrazioneSoap.get(CostantiPdD.HEADER_INTEGRAZIONE_ID_APPLICATIVO)) {
  1009.                     idApplicativo = headerElement.getAttribute((String)this.keyValueIntegrazioneSoap.get(CostantiPdD.HEADER_INTEGRAZIONE_ID_APPLICATIVO));
  1010.                 }
  1011.             }catch(Exception e){}
  1012.             if(idApplicativo!=null && idApplicativo.compareTo("")!=0)
  1013.                 integrazione.setIdApplicativo(idApplicativo);

  1015.             String sa = null;
  1016.             try{
  1017.                 if(this.keyReadEnabled_HeaderIntegrazioneSoap.get(CostantiPdD.HEADER_INTEGRAZIONE_SERVIZIO_APPLICATIVO)) {
  1018.                     sa = headerElement.getAttribute((String)this.keyValueIntegrazioneSoap.get(CostantiPdD.HEADER_INTEGRAZIONE_SERVIZIO_APPLICATIVO));
  1019.                 }
  1020.             }catch(Exception e){}
  1021.             if(sa!=null && sa.compareTo("")!=0)
  1022.                 integrazione.setServizioApplicativo(sa);
  1023.             
  1024.             String tipoMittenteToken = null;
  1025.             try{
  1026.                 if(this.keyReadEnabled_HeaderIntegrazioneSoap.get(CostantiPdD.HEADER_INTEGRAZIONE_TIPO_MITTENTE_TOKEN)) {
  1027.                     tipoMittenteToken = headerElement.getAttribute((String)this.keyValueIntegrazioneSoap.get(CostantiPdD.HEADER_INTEGRAZIONE_TIPO_MITTENTE_TOKEN));
  1028.                 }
  1029.             }catch(Exception e){}
  1030.             if(tipoMittenteToken!=null && tipoMittenteToken.compareTo("")!=0)
  1031.                 integrazione.setTipoSoggettoProprietarioApplicativoToken(tipoMittenteToken);
  1032.             
  1033.             String mittenteToken = null;
  1034.             try{
  1035.                 if(this.keyReadEnabled_HeaderIntegrazioneSoap.get(CostantiPdD.HEADER_INTEGRAZIONE_MITTENTE_TOKEN)) {
  1036.                     mittenteToken = headerElement.getAttribute((String)this.keyValueIntegrazioneSoap.get(CostantiPdD.HEADER_INTEGRAZIONE_MITTENTE_TOKEN));
  1037.                 }
  1038.             }catch(Exception e){}
  1039.             if(mittenteToken!=null && mittenteToken.compareTo("")!=0)
  1040.                 integrazione.setNomeSoggettoProprietarioApplicativoToken(mittenteToken);
  1041.             
  1042.             String saToken = null;
  1043.             try{
  1044.                 if(this.keyReadEnabled_HeaderIntegrazioneSoap.get(CostantiPdD.HEADER_INTEGRAZIONE_SERVIZIO_APPLICATIVO_TOKEN)) {
  1045.                     saToken = headerElement.getAttribute((String)this.keyValueIntegrazioneSoap.get(CostantiPdD.HEADER_INTEGRAZIONE_SERVIZIO_APPLICATIVO_TOKEN));
  1046.                 }
  1047.             }catch(Exception e){}
  1048.             if(sa!=null && sa.compareTo("")!=0)
  1049.                 integrazione.setServizioApplicativoToken(saToken);
  1050.             
  1051.             String idTransazione = null;
  1052.             try{
  1053.                 if(this.keyReadEnabled_HeaderIntegrazioneSoap.get(CostantiPdD.HEADER_INTEGRAZIONE_ID_TRANSAZIONE)) {
  1054.                     idTransazione = headerElement.getAttribute((String)this.keyValueIntegrazioneSoap.get(CostantiPdD.HEADER_INTEGRAZIONE_ID_TRANSAZIONE));
  1055.                 }
  1056.             }catch(Exception e){}
  1057.             if(idTransazione!=null && idTransazione.compareTo("")!=0)
  1058.                 integrazione.setIdTransazione(idTransazione);
  1059.             
  1060.         }catch(Exception e){
  1061.             throw new HeaderIntegrazioneException("UtilitiesIntegrazione, lettura dell'header soap non riuscita: "+e.getMessage(),e);
  1062.         }
  1063.     }

  1065.     public void updateHeader(OpenSPCoop2SoapMessage message,IDSoggetto soggettoFruitore,IDServizio idServizio,
  1066.             String idBusta,String servizioApplicativo,
  1067.             String correlazioneApplicativa,String riferimentoCorrelazioneApplicativaRichiesta, String idTransazione,
  1068.             String actorIntegrazione,String nomeElemento,String prefix,String namespace,
  1069.             String proprietaProtocolloNomeElemento,String proprietaProtocolloNomeTipoElemento,
  1070.             Map<String, String> protocolInfos) throws Exception{
  1071.         updateHeader(message, soggettoFruitore, idServizio, idBusta, null, 
  1072.                 servizioApplicativo, correlazioneApplicativa, riferimentoCorrelazioneApplicativaRichiesta, idTransazione,
  1073.                 actorIntegrazione, nomeElemento, prefix, namespace, 
  1074.                 proprietaProtocolloNomeElemento, proprietaProtocolloNomeTipoElemento, protocolInfos);
  1075.     }
  1076.     
  1077.     public void updateHeader(OpenSPCoop2SoapMessage message,IDSoggetto soggettoFruitore,IDServizio idServizio,
  1078.             String idBusta,String idBustaRisposta,String servizioApplicativo,
  1079.             String correlazioneApplicativa,String riferimentoCorrelazioneApplicativaRichiesta, String idTransazione,
  1080.             String actorIntegrazione,String nomeElemento,String prefix,String namespace,
  1081.             String proprietaProtocolloNomeElemento,String proprietaProtocolloNomeTipoElemento,
  1082.             Map<String, String> protocolInfos) throws Exception{
  1083.         
  1084.         HeaderIntegrazione integrazione = new HeaderIntegrazione(idTransazione);
  1085.         integrazione.setIdApplicativo(correlazioneApplicativa);
  1086.         integrazione.setServizioApplicativo(servizioApplicativo);
  1087.         HeaderIntegrazioneBusta busta = new HeaderIntegrazioneBusta();
  1088.         busta.setTipoMittente(soggettoFruitore.getTipo());
  1089.         busta.setMittente(soggettoFruitore.getNome());
  1090.         busta.setTipoDestinatario(idServizio.getSoggettoErogatore().getTipo());
  1091.         busta.setDestinatario(idServizio.getSoggettoErogatore().getNome());
  1092.         busta.setTipoServizio(idServizio.getTipo());
  1093.         busta.setServizio(idServizio.getNome());
  1094.         busta.setVersioneServizio(idServizio.getVersione());
  1095.         busta.setAzione(idServizio.getAzione());
  1096.         if(idBustaRisposta==null){
  1097.             busta.setID(idBusta);
  1098.         }
  1099.         else{
  1100.             busta.setID(idBustaRisposta);
  1101.             busta.setRiferimentoMessaggio(idBusta);
  1102.         }
  1103.         integrazione.setBusta(busta);
  1104.         
  1105.         this.updateHeader(message, integrazione, actorIntegrazione, nomeElemento, prefix, namespace, 
  1106.                 proprietaProtocolloNomeElemento, proprietaProtocolloNomeTipoElemento, protocolInfos);
  1107.     }
  1108.         
  1109.     public void updateHeader(OpenSPCoop2SoapMessage message,HeaderIntegrazione integrazione,
  1110.             String actorIntegrazione,String nomeElemento,String prefix,String namespace,
  1111.             String proprietaProtocolloNomeElemento,String proprietaProtocolloNomeTipoElemento,
  1112.             Map<String, String> protocolInfos) throws Exception{
  1113.         
  1114.         if(actorIntegrazione==null)
  1115.             throw new Exception("Actor non definito");
  1116.         SOAPHeader header = message.getSOAPHeader();
  1117.         SOAPHeaderElement headerIntegrazione = null;
  1118.         if(header==null){
  1119.             
  1120.             // Creo soap header
  1121.             OpenSPCoop2Logger.getLoggerOpenSPCoopCore().debug("SOAPHeader non presente: add soapHeader");
  1122.             header = message.getSOAPPart().getEnvelope().addHeader();
  1123.             
  1124.         }else{

  1126.             // cerco soap di integrazione
  1127.             java.util.Iterator<?> it = header.examineAllHeaderElements();
  1128.             while( it.hasNext()  ){
  1129.                 // Test Header Element
  1130.                 headerIntegrazione = (SOAPHeaderElement) it.next();
  1131.                 //Controllo Actor
  1132.                 String actorCheck = SoapUtils.getSoapActor(headerIntegrazione, message.getMessageType());
  1133.                 if( actorIntegrazione.equals(actorCheck) ){
  1134.                     break;
  1135.                 }else{
  1136.                     headerIntegrazione = null;
  1137.                 }
  1138.             }
  1139.             if(headerIntegrazione==null){
  1140.                 OpenSPCoop2Logger.getLoggerOpenSPCoopCore().debug("Header di integrazione non presente, lo creo");
  1141.             }
  1142.         }

  1144.         List<SOAPElement> v = new ArrayList<SOAPElement>(); // mantengo eventuali message element presenti
  1145.         if(headerIntegrazione!=null){
  1146.             
  1147.             java.util.Iterator<?> it = headerIntegrazione.getChildElements();
  1148.             if(it.hasNext()){
  1149.                 SOAPElement tmp = (SOAPElement) it.next();
  1150.                 //System.out.println("CONSERVO MSG ELEMENT["+tmp.getLocalName()+"]");
  1151.                 v.add(tmp);
  1152.             }
  1153.              
  1154.             header.removeChild(headerIntegrazione);
  1155.         }
  1156.         
  1157.         // creo header da nuovo
  1158.         SOAPHeaderElement headerIntegrazioneNEW = this.buildHeader(integrazione, nomeElemento, prefix, namespace, 
  1159.                 actorIntegrazione, message, 
  1160.                 proprietaProtocolloNomeElemento, proprietaProtocolloNomeTipoElemento, protocolInfos);   
  1161.         
  1162.         // Riaggiungo eventuali elementi interni
  1163.         while(v.size()>0){
  1164.             SOAPElement tmp = v.remove(0);
  1165.             //System.out.println("RIAGGIUNGO MSG ELEMENT["+tmp.getLocalName()+"]");
  1166.             headerIntegrazioneNEW.addChildElement(tmp);
  1167.         }
  1168.         
  1169.         //System.out.println("OTTENGO ["+headerIntegrazioneNEW.getAsString()+"]");
  1170.         
  1171.         // aggiungo header element al SOAP Header
  1172.         //header.addChildElement(headerIntegrazioneNEW);
  1173.         message.addHeaderElement(header, headerIntegrazioneNEW);

  1175.     }
  1176.     
  1177.     public SOAPHeaderElement buildHeader(HeaderIntegrazione integrazione,String nomeElemento,
  1178.             String prefix,String namespace, String actor, 
  1179.             OpenSPCoop2SoapMessage m,
  1180.             String proprietaProtocolloNomeElemento,String proprietaProtocolloNomeTipoElemento,
  1181.             Map<String, String> protocolInfos) throws HeaderIntegrazioneException{

  1183.         try{
  1184.             SOAPHeader soapHeader = m.getSOAPHeader();
  1185.             if(soapHeader==null){
  1186.                 soapHeader = m.getSOAPPart().getEnvelope().addHeader();
  1187.             }
  1188.             SOAPHeaderElement header = m.newSOAPHeaderElement(soapHeader, new QName(namespace,nomeElemento,prefix));

  1190.             header.setActor(actor);
  1191.             header.setMustUnderstand(false);
  1192.             
  1193.             setAttributes(integrazione,header);
  1194.             
  1195.             if(this.keySetEnabled_HeaderIntegrazioneSoap.get(CostantiPdD.HEADER_INTEGRAZIONE_PROTOCOL_INFO)) {
  1196.                 if(protocolInfos!=null && protocolInfos.size()>0){
  1197.                     
  1198.                     String prefixProtocolInfo = this.keyValueIntegrazioneSoap.get(CostantiPdD.HEADER_INTEGRAZIONE_PROTOCOL_INFO);
  1199.                     
  1200.                     Iterator<String> itProtocolInfos = protocolInfos.keySet().iterator();
  1201.                     while (itProtocolInfos.hasNext()) {
  1202.                         String name = (String) itProtocolInfos.next();
  1203.                         String value = protocolInfos.get(name);
  1204.                         String nameWithPrefix = (prefixProtocolInfo!=null) ? prefixProtocolInfo.trim()+name : name;
  1205.                         SOAPElement element = header.addChildElement(new QName(namespace,proprietaProtocolloNomeElemento,prefix));
  1206.                         element.setTextContent(value);
  1207.                         @SuppressWarnings("unused")
  1208.                         SOAPElement attribute = element.addAttribute(new QName(proprietaProtocolloNomeTipoElemento),nameWithPrefix);
  1209.                     }
  1210.                 }
  1211.             }
  1212.             
  1213.             return header;

  1215.         }catch(Exception e){
  1216.             throw new HeaderIntegrazioneException("UtilitiesIntegrazione, creazione dell'header soap non riuscita: "+e.getMessage(),e);
  1217.         }
  1218.     }
  1219.     
  1220.     
  1221.     public void setAttributes(HeaderIntegrazione integrazione, SOAPHeaderElement header){
  1222.         if(integrazione.getBusta()!=null){

  1224.             if(integrazione.getBusta().getTipoMittente()!=null){
  1225.                 if(this.keySetEnabled_HeaderIntegrazioneSoap.get(CostantiPdD.HEADER_INTEGRAZIONE_TIPO_MITTENTE)) {
  1226.                     header.setAttribute((String)this.keyValueIntegrazioneSoap.get(CostantiPdD.HEADER_INTEGRAZIONE_TIPO_MITTENTE), integrazione.getBusta().getTipoMittente());
  1227.                 }
  1228.             }
  1229.             if(integrazione.getBusta().getMittente()!=null){
  1230.                 if(this.keySetEnabled_HeaderIntegrazioneSoap.get(CostantiPdD.HEADER_INTEGRAZIONE_MITTENTE)) {
  1231.                     header.setAttribute((String)this.keyValueIntegrazioneSoap.get(CostantiPdD.HEADER_INTEGRAZIONE_MITTENTE), integrazione.getBusta().getMittente());
  1232.                 }
  1233.             }

  1235.             if(integrazione.getBusta().getTipoDestinatario()!=null){
  1236.                 if(this.keySetEnabled_HeaderIntegrazioneSoap.get(CostantiPdD.HEADER_INTEGRAZIONE_TIPO_DESTINATARIO)) {
  1237.                     header.setAttribute((String)this.keyValueIntegrazioneSoap.get(CostantiPdD.HEADER_INTEGRAZIONE_TIPO_DESTINATARIO), integrazione.getBusta().getTipoDestinatario());
  1238.                 }
  1239.             }
  1240.             if(integrazione.getBusta().getDestinatario()!=null){
  1241.                 if(this.keySetEnabled_HeaderIntegrazioneSoap.get(CostantiPdD.HEADER_INTEGRAZIONE_DESTINATARIO)) {
  1242.                     header.setAttribute((String)this.keyValueIntegrazioneSoap.get(CostantiPdD.HEADER_INTEGRAZIONE_DESTINATARIO), integrazione.getBusta().getDestinatario());
  1243.                 }
  1244.             }

  1246.             if(integrazione.getBusta().getTipoServizio()!=null){
  1247.                 if(this.keySetEnabled_HeaderIntegrazioneSoap.get(CostantiPdD.HEADER_INTEGRAZIONE_TIPO_SERVIZIO)) {
  1248.                     header.setAttribute((String)this.keyValueIntegrazioneSoap.get(CostantiPdD.HEADER_INTEGRAZIONE_TIPO_SERVIZIO), integrazione.getBusta().getTipoServizio());
  1249.                 }
  1250.             }
  1251.             if(integrazione.getBusta().getServizio()!=null){
  1252.                 if(this.keySetEnabled_HeaderIntegrazioneSoap.get(CostantiPdD.HEADER_INTEGRAZIONE_SERVIZIO)) {
  1253.                     header.setAttribute((String)this.keyValueIntegrazioneSoap.get(CostantiPdD.HEADER_INTEGRAZIONE_SERVIZIO), integrazione.getBusta().getServizio());
  1254.                 }
  1255.             }
  1256.             if(integrazione.getBusta().getVersioneServizio()!=null){
  1257.                 if(this.keySetEnabled_HeaderIntegrazioneSoap.get(CostantiPdD.HEADER_INTEGRAZIONE_VERSIONE_SERVIZIO)) {
  1258.                     header.setAttribute((String)this.keyValueIntegrazioneSoap.get(CostantiPdD.HEADER_INTEGRAZIONE_VERSIONE_SERVIZIO), integrazione.getBusta().getVersioneServizio().intValue()+"");
  1259.                 }
  1260.             }

  1262.             if(integrazione.getBusta().getAzione()!=null){
  1263.                 if(this.keySetEnabled_HeaderIntegrazioneSoap.get(CostantiPdD.HEADER_INTEGRAZIONE_AZIONE)) {
  1264.                     header.setAttribute((String)this.keyValueIntegrazioneSoap.get(CostantiPdD.HEADER_INTEGRAZIONE_AZIONE), integrazione.getBusta().getAzione());
  1265.                 }
  1266.             }

  1268.             if(integrazione.getBusta().getID()!=null){
  1269.                 if(this.keySetEnabled_HeaderIntegrazioneSoap.get(CostantiPdD.HEADER_INTEGRAZIONE_ID_MESSAGGIO)) {
  1270.                     header.setAttribute((String)this.keyValueIntegrazioneSoap.get(CostantiPdD.HEADER_INTEGRAZIONE_ID_MESSAGGIO), integrazione.getBusta().getID());
  1271.                 }
  1272.             }

  1274.             if(integrazione.getBusta().getRiferimentoMessaggio()!=null){
  1275.                 if(this.keySetEnabled_HeaderIntegrazioneSoap.get(CostantiPdD.HEADER_INTEGRAZIONE_RIFERIMENTO_MESSAGGIO)) {
  1276.                     header.setAttribute((String)this.keyValueIntegrazioneSoap.get(CostantiPdD.HEADER_INTEGRAZIONE_RIFERIMENTO_MESSAGGIO), integrazione.getBusta().getRiferimentoMessaggio());
  1277.                 }
  1278.             }

  1280.             if(integrazione.getBusta().getIdCollaborazione()!=null){
  1281.                 if(this.keySetEnabled_HeaderIntegrazioneSoap.get(CostantiPdD.HEADER_INTEGRAZIONE_COLLABORAZIONE)) {
  1282.                     header.setAttribute((String)this.keyValueIntegrazioneSoap.get(CostantiPdD.HEADER_INTEGRAZIONE_COLLABORAZIONE), integrazione.getBusta().getIdCollaborazione());
  1283.                 }
  1284.             }
  1285.         }

  1287.         if(integrazione.getIdApplicativo()!=null){
  1288.             if(this.keySetEnabled_HeaderIntegrazioneSoap.get(CostantiPdD.HEADER_INTEGRAZIONE_ID_APPLICATIVO)) {
  1289.                 header.setAttribute((String)this.keyValueIntegrazioneSoap.get(CostantiPdD.HEADER_INTEGRAZIONE_ID_APPLICATIVO), integrazione.getIdApplicativo());
  1290.             }
  1291.         }
  1292.         
  1293.         if(integrazione.getServizioApplicativo()!=null){
  1294.             if(this.keySetEnabled_HeaderIntegrazioneSoap.get(CostantiPdD.HEADER_INTEGRAZIONE_SERVIZIO_APPLICATIVO)) {
  1295.                 header.setAttribute((String)this.keyValueIntegrazioneSoap.get(CostantiPdD.HEADER_INTEGRAZIONE_SERVIZIO_APPLICATIVO), integrazione.getServizioApplicativo());
  1296.             }
  1297.         }
  1298.         
  1299.         if(integrazione.getTipoSoggettoProprietarioApplicativoToken()!=null){
  1300.             if(this.keySetEnabled_HeaderIntegrazioneSoap.get(CostantiPdD.HEADER_INTEGRAZIONE_TIPO_MITTENTE_TOKEN)) {
  1301.                 header.setAttribute((String)this.keyValueIntegrazioneSoap.get(CostantiPdD.HEADER_INTEGRAZIONE_TIPO_MITTENTE_TOKEN), integrazione.getTipoSoggettoProprietarioApplicativoToken());
  1302.             }
  1303.         }
  1304.         if(integrazione.getNomeSoggettoProprietarioApplicativoToken()!=null){
  1305.             if(this.keySetEnabled_HeaderIntegrazioneSoap.get(CostantiPdD.HEADER_INTEGRAZIONE_MITTENTE_TOKEN)) {
  1306.                 header.setAttribute((String)this.keyValueIntegrazioneSoap.get(CostantiPdD.HEADER_INTEGRAZIONE_MITTENTE_TOKEN), integrazione.getNomeSoggettoProprietarioApplicativoToken());
  1307.             }
  1308.         }
  1309.         
  1310.         if(integrazione.getServizioApplicativoToken()!=null){
  1311.             if(this.keySetEnabled_HeaderIntegrazioneSoap.get(CostantiPdD.HEADER_INTEGRAZIONE_SERVIZIO_APPLICATIVO_TOKEN)) {
  1312.                 header.setAttribute((String)this.keyValueIntegrazioneSoap.get(CostantiPdD.HEADER_INTEGRAZIONE_SERVIZIO_APPLICATIVO_TOKEN), integrazione.getServizioApplicativoToken());
  1313.             }
  1314.         }
  1315.         
  1316.         if(integrazione.getIdTransazione()!=null){
  1317.             if(this.keySetEnabled_HeaderIntegrazioneSoap.get(CostantiPdD.HEADER_INTEGRAZIONE_ID_TRANSAZIONE)) {
  1318.                 header.setAttribute((String)this.keyValueIntegrazioneSoap.get(CostantiPdD.HEADER_INTEGRAZIONE_ID_TRANSAZIONE), integrazione.getIdTransazione());
  1319.             }
  1320.         }
  1321.         
  1322.         if(this.keySetEnabled_HeaderIntegrazioneSoap.get(CostantiPdD.HEADER_INTEGRAZIONE_INFO)) {
  1323.             
  1324.             header.setAttribute(CostantiPdD.HEADER_INTEGRAZIONE_SOAP_PDD_VERSION, this.openspcoopProperties.getHeaderIntegrazioneSOAPPdDVersione());
  1325.             if(this.openspcoopProperties.getHeaderIntegrazioneSOAPPdDDetails()!=null && !"".equals(this.openspcoopProperties.getHeaderIntegrazioneSOAPPdDDetails())){
  1326.                 header.setAttribute(CostantiPdD.HEADER_INTEGRAZIONE_SOAP_PDD_DETAILS, this.openspcoopProperties.getHeaderIntegrazioneSOAPPdDDetails());
  1327.             }
  1328.             
  1329.         }

  1331.     }
  1332.     
  1333.     
  1334.     public void deleteHeader(OpenSPCoop2SoapMessage message,String actorIntegrazione) throws HeaderIntegrazioneException{

  1336.         try{

  1338.             if(actorIntegrazione==null)
  1339.                 throw new Exception("Actor non definito");
  1340.             SOAPHeader header = message.getSOAPHeader();
  1341.             if(header==null){
  1342.                 OpenSPCoop2Logger.getLoggerOpenSPCoopCore().debug("SOAPHeader non presente");
  1343.                 return;
  1344.             }
  1345.             SOAPHeaderElement headerElement = null;
  1346.             java.util.Iterator<?> it = header.examineAllHeaderElements();
  1347.             while( it.hasNext()  ){
  1348.                 // Test Header Element
  1349.                 headerElement = (SOAPHeaderElement) it.next();
  1350.                 //Controllo Actor
  1351.                 String actorCheck = SoapUtils.getSoapActor(headerElement, message.getMessageType());
  1352.                 if( actorIntegrazione.equals(actorCheck) ){
  1353.                     break;
  1354.                 }else{
  1355.                     headerElement = null;
  1356.                 }
  1357.             }
  1358.             if(headerElement==null){
  1359.                 OpenSPCoop2Logger.getLoggerOpenSPCoopCore().debug("Header di integrazione non presente");
  1360.                 return;
  1361.             }
  1362.             
  1363.             header.removeChild(headerElement);
  1364.             
  1365.         }catch(Exception e){
  1366.             throw new HeaderIntegrazioneException("UtilitiesIntegrazione, eliminazione dell'header soap non riuscita: "+e.getMessage(),e);
  1367.         }
  1368.     }
  1369.     
  1370.     public static String getIdTransazione(PdDContext context){
  1371.         if(context!=null){
  1372.             return (String) context.getObject(Costanti.ID_TRANSAZIONE);
  1373.         }
  1374.         else{
  1375.             return null;
  1376.         }
  1377.     }
  1378. }
Created with JaCoCo 0.8.8.202204050719