UtilitiesIntegrazioneWSAddressing.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;

  25. import java.util.Iterator;

  27. import javax.xml.soap.SOAPElement;
  28. import javax.xml.soap.SOAPHeader;
  29. import javax.xml.soap.SOAPHeaderElement;

  31. import org.openspcoop2.core.id.IDServizio;
  32. import org.openspcoop2.core.id.IDSoggetto;
  33. import org.openspcoop2.message.OpenSPCoop2SoapMessage;
  34. import org.openspcoop2.message.soap.wsaddressing.Costanti;
  35. import org.openspcoop2.message.soap.wsaddressing.WSAddressingHeader;
  36. import org.openspcoop2.message.soap.wsaddressing.WSAddressingUtilities;
  37. import org.openspcoop2.pdd.logger.OpenSPCoop2Logger;
  38. import org.slf4j.Logger;


  41. /**
  42.  * Classe contenenti utilities per le integrazioni.
  43.  *
  44.  * @author Poli Andrea (apoli@link.it)
  45.  * @author $Author$
  46.  * @version $Rev$, $Date$
  47.  */
  48. public class UtilitiesIntegrazioneWSAddressing {

  50.     // ***** STATIC *****
  51.     
  52.     /**
  53.        SOAPHeaderElement wsaTO        ->     http://<providerType>_<provider>.govway.org/services/<serviceType>_<service>/<serviceVersion>
  54.        SOAPHeaderElement wsaFROM      ->     http://[<application>.]<senderType>_<sender>.govway.org
  55.        SOAPHeaderElement wsaAction    ->     http://<providerType>_<provider>.govway.org/services/<serviceType>_<service>/<serviceVersion>/<action>
  56.        SOAPHeaderElement wsaID        ->     uuid:<messageId> in caso di Messaggio di Protocollo (restituzione di una risposto lato PD o in caso di consegna tramite PA
  57.                                              uuid:<applicationMessageId> in caso di Messaggio di Integrazione (invocazione lato PD o lettura risposta lato PA, es. per correlazione applicativa)
  58.        SOAPHeaderElement wsaRelatesTo ->     uuid:<messageId> equivale al riferimento messaggio
  59.      */
  60.     private static final String WSA_TO_FORMAT = "http://<providerType>_<provider>.govway.org/services/<serviceType>_<service>/<serviceVersion>";
  61.     private static final String WSA_FROM_FORMAT = "http://[<application>.]<senderType>_<sender>.govway.org";
  62.     private static final String WSA_ACTION_FORMAT = "http://<providerType>_<provider>.govway.org/services/<serviceType>_<service>/<serviceVersion>/<action>";
  63.     private static final String WSA_ID_FORMAT = "uuid:<id>";
  64.     private static final String WSA_RELATES_TO_FORMAT = "uuid:<id>";
  65.     
  66.     public static final boolean INTERPRETA_COME_ID_BUSTA = true;
  67.     public static final boolean INTERPRETA_COME_ID_APPLICATIVO = false;
  68.     
  69.     private static final boolean MUST_UNDERSTAND = false;
  70.     
  71.     
  72.     public static void _readDatiWSAToOrAction(String wsaValue,String format, HeaderIntegrazione integrazione) throws HeaderIntegrazioneException{
  73.         
  74.         String type = null;
  75.         boolean action = false;
  76.         if(WSA_TO_FORMAT.equals(format)){
  77.             type = "WSAddressingTo";    
  78.         }
  79.         else if(WSA_ACTION_FORMAT.equals(format)){
  80.             type = "WSAddressingAction";    
  81.             action = true;
  82.         }
  83.         else{
  84.             throw new HeaderIntegrazioneException("Format ["+format+"] Not Supported");
  85.         }
  86.         
  87.         if(wsaValue==null)
  88.             throw new HeaderIntegrazioneException(type+" value is null");
  89.         wsaValue = wsaValue.trim();
  90.         if(wsaValue.startsWith("http://")==false)
  91.             throw new HeaderIntegrazioneException(type+" Value is not valid: "+format);
  92.         if(wsaValue.contains(".govway.org/services/")==false)
  93.             throw new HeaderIntegrazioneException(type+" Value is not valid: "+format);
  94.         
  95.         wsaValue = wsaValue.substring(7, wsaValue.length());
  96.         
  97.         // soggetto
  98.         int indexSoggetto = wsaValue.indexOf(".govway.org/services/");
  99.         String soggetto = wsaValue.substring(0, indexSoggetto);
  100.         if(soggetto==null){
  101.             throw new HeaderIntegrazioneException(type+" Value is not valid (Soggetto non identificabile): "+format);
  102.         }
  103.         if(soggetto.contains("_")==false){
  104.             throw new HeaderIntegrazioneException(type+" Value is not valid (Soggetto non identificabile, '_' non trovato ): "+format);
  105.         }
  106.         String [] soggetto_split = soggetto.split("_");
  107.         if(soggetto_split==null || soggetto_split.length<2){
  108.             throw new HeaderIntegrazioneException(type+" Value is not valid (Soggetto non identificabile, formato errato ): "+format);
  109.         }
  110.         
  111.         String tipoSoggetto = soggetto_split[0];
  112.         if(tipoSoggetto!=null){
  113.             tipoSoggetto = tipoSoggetto.trim();
  114.         }
  115.         if(tipoSoggetto==null || "".equals(tipoSoggetto)){
  116.             throw new HeaderIntegrazioneException(type+" Value is not valid (TipoSoggetto non identificabile): "+format);
  117.         }
  118.         
  119.         String nomeSoggetto = soggetto.substring((tipoSoggetto+"_").length());
  120.         if(nomeSoggetto!=null){
  121.             nomeSoggetto = nomeSoggetto.trim();
  122.         }
  123.         if(nomeSoggetto==null || "".equals(nomeSoggetto)){
  124.             throw new HeaderIntegrazioneException(type+" Value is not valid (NomeSoggetto non identificabile): "+format);
  125.         }

  127.         if(!action){
  128.             integrazione.getBusta().setTipoDestinatario(tipoSoggetto);
  129.             integrazione.getBusta().setDestinatario(nomeSoggetto);
  130.         }
  131.         
  132.         // servizio
  133.         String servizio = wsaValue.substring((indexSoggetto+".govway.org/services/".length()), wsaValue.length());
  134.         if(servizio==null){
  135.             throw new HeaderIntegrazioneException(type+" Value is not valid (Servizio non identificabile): "+format);
  136.         }
  137.         if(servizio.contains("_")==false){
  138.             throw new HeaderIntegrazioneException(type+" Value is not valid (Servizio non identificabile, '_' non trovato ): "+format);
  139.         }
  140.         String [] servizio_split = servizio.split("_");
  141.         if(servizio_split==null || servizio_split.length<2){
  142.             throw new HeaderIntegrazioneException(type+" Value is not valid (Servizio non identificabile, formato errato ): "+format);
  143.         }
  144.         String tipoServizio = servizio_split[0];
  145.         if(tipoServizio!=null){
  146.             tipoServizio = tipoServizio.trim();
  147.         }
  148.         if(tipoServizio==null || "".equals(tipoServizio)){
  149.             throw new HeaderIntegrazioneException(type+" Value is not valid (TipoServizio non identificabile): "+format);
  150.         }
  151.         
  152.         String nomeVersioneServizio = servizio.substring((tipoServizio+"_").length());
  153.         if(nomeVersioneServizio!=null){
  154.             nomeVersioneServizio = nomeVersioneServizio.trim();
  155.         }
  156.         if(nomeVersioneServizio==null || "".equals(nomeVersioneServizio)){
  157.             throw new HeaderIntegrazioneException(type+" Value is not valid (Nome e VersioneServizio non identificabile): "+format);
  158.         }
  159.         if(nomeVersioneServizio.contains("/")==false){
  160.             throw new HeaderIntegrazioneException(type+" Value is not valid (Nome e VersioneServizio non identificabile, '/' non trovato ): "+format);
  161.         }
  162.         
  163.         if(action){
  164.             // gli slash sono due
  165.             // nomeVersioneServizio contiene anche l'azione
  166.             
  167.             int indexAzione = nomeVersioneServizio.lastIndexOf("/");
  168.             if(indexAzione<=0){
  169.                 throw new HeaderIntegrazioneException(type+" Value is not valid (Azione non identificabile, '/' non trovato, index("+indexAzione+") ): "+format);
  170.             }
  171.             
  172.             String azione = nomeVersioneServizio.substring(indexAzione+1);
  173.             if(azione!=null){
  174.                 azione = azione.trim();
  175.             }
  176.             if(azione==null  || "".equals(azione)){
  177.                 throw new HeaderIntegrazioneException(type+" Value is not valid (Azione non identificabile): "+format);
  178.             }
  179.             
  180.             integrazione.getBusta().setAzione(azione);
  181.             
  182.             nomeVersioneServizio =  nomeVersioneServizio.substring(0, indexAzione);
  183.             if(nomeVersioneServizio!=null){
  184.                 nomeVersioneServizio = nomeVersioneServizio.trim();
  185.             }
  186.             if(nomeVersioneServizio==null || "".equals(nomeVersioneServizio)){
  187.                 throw new HeaderIntegrazioneException(type+" Value is not valid (Nome e VersioneServizio non identificabile non identificabile prima dell'Azione): "+format);
  188.             }
  189.         }
  190.         
  191.             
  192.         int indexVersioneServizio = nomeVersioneServizio.lastIndexOf("/");
  193.         if(indexVersioneServizio<=0){
  194.             throw new HeaderIntegrazioneException(type+" Value is not valid (VersioneServizio non identificabile, '/' non trovato, index("+indexVersioneServizio+") ): "+format);
  195.         }
  196.         
  197.         String nomeServizio = nomeVersioneServizio.substring(0, indexVersioneServizio);
  198.         if(nomeServizio!=null){
  199.             nomeServizio = nomeServizio.trim();
  200.         }
  201.         if(nomeServizio==null || "".equals(nomeServizio)){
  202.             throw new HeaderIntegrazioneException(type+" Value is not valid (NomeServizio non identificabile): "+format);
  203.         }
  204.         
  205.         String tmpVersioneServizio = nomeVersioneServizio.substring(indexVersioneServizio+1);
  206.         if(tmpVersioneServizio!=null){
  207.             tmpVersioneServizio = tmpVersioneServizio.trim();
  208.         }
  209.         if(tmpVersioneServizio==null  || "".equals(tmpVersioneServizio)){
  210.             throw new HeaderIntegrazioneException(type+" Value is not valid (VersioneServizio non identificabile): "+format);
  211.         }
  212.         Integer versioneServizio = null;
  213.         try{
  214.             versioneServizio = Integer.parseInt(tmpVersioneServizio);
  215.         }catch(Exception e){
  216.             throw new HeaderIntegrazioneException(type+" Value is not valid (VersioneServizio non identificabile, formato errato "+e.getMessage()+"): "+format);
  217.         }
  218.         
  219.         if(!action){
  220.             integrazione.getBusta().setTipoServizio(tipoServizio);
  221.             integrazione.getBusta().setServizio(nomeServizio);
  222.             integrazione.getBusta().setVersioneServizio(versioneServizio);
  223.         }
  224.         
  225.     }
  226.     
  227.     
  228.     public static void readDatiWSATo(String wsaTO,HeaderIntegrazione integrazione) throws HeaderIntegrazioneException{
  229.         _readDatiWSAToOrAction(wsaTO, WSA_TO_FORMAT, integrazione);
  230.     }
  231.     public static String buildDatiWSATo(String tipoSoggettoErogatore,String nomeSoggettoErogatore,String tipoServizio,String nomeServizio,Integer versioneServizio){
  232.         return "http://"+tipoSoggettoErogatore+"_"+nomeSoggettoErogatore+".govway.org/services/"+tipoServizio+"_"+nomeServizio+"/"+versioneServizio;
  233.     }
  234.     public static SOAPHeaderElement buildWSATo(OpenSPCoop2SoapMessage msg,String actor,String tipoSoggettoErogatore,String nomeSoggettoErogatore,String tipoServizio,String nomeServizio,Integer versioneServizio) throws Exception{
  235.         return WSAddressingUtilities.buildWSATo(msg, actor, MUST_UNDERSTAND,
  236.                 UtilitiesIntegrazioneWSAddressing.buildDatiWSATo(tipoSoggettoErogatore,nomeSoggettoErogatore,tipoServizio,nomeServizio,versioneServizio));
  237.     }
  238.     
  239.     
  240.     public static void readDatiWSAFrom(String wsaFrom,HeaderIntegrazione integrazione) throws HeaderIntegrazioneException{
  241.         if(wsaFrom==null)
  242.             throw new HeaderIntegrazioneException("WSAFrom value is null");
  243.         wsaFrom = wsaFrom.trim();
  244.         if(wsaFrom.startsWith("http://")==false)
  245.             throw new HeaderIntegrazioneException("WSAFrom Value is not valid: "+WSA_FROM_FORMAT);
  246.         if(wsaFrom.contains(".govway.org")==false)
  247.             throw new HeaderIntegrazioneException("WSAFrom Value is not valid: "+WSA_FROM_FORMAT);
  248.         
  249.         wsaFrom = wsaFrom.substring(7, wsaFrom.length());
  250.         
  251.         int indexSoggetto = wsaFrom.indexOf(".govway.org");
  252.         String soggetto = wsaFrom.substring(0, indexSoggetto);
  253.         if(soggetto==null){
  254.             throw new HeaderIntegrazioneException("WSAFrom Value is not valid (Soggetto non identificabile): "+WSA_FROM_FORMAT);
  255.         }   
  256.         if(soggetto.contains("_")==false){
  257.             throw new HeaderIntegrazioneException("WSAFrom Value is not valid (Soggetto non identificabile, '_' non trovato ): "+WSA_FROM_FORMAT);
  258.         }
  259.         String [] soggetto_split = soggetto.split("_");
  260.         if(soggetto_split==null || soggetto_split.length<2){
  261.             throw new HeaderIntegrazioneException("WSAFrom Value is not valid (Soggetto non identificabile, formato errato ): "+WSA_FROM_FORMAT);
  262.         }
  263.         
  264.         String tipoSoggetto = soggetto_split[0];
  265.         if(tipoSoggetto!=null){
  266.             tipoSoggetto = tipoSoggetto.trim();
  267.         }
  268.         if(tipoSoggetto==null || "".equals(tipoSoggetto)){
  269.             throw new HeaderIntegrazioneException("WSAFrom Value is not valid (TipoSoggetto non identificabile): "+WSA_FROM_FORMAT);
  270.         }
  271.         
  272.         String nomeSoggetto = soggetto.substring((tipoSoggetto+"_").length());
  273.         if(nomeSoggetto!=null){
  274.             nomeSoggetto = nomeSoggetto.trim();
  275.         }
  276.         if(nomeSoggetto==null || "".equals(nomeSoggetto)){
  277.             throw new HeaderIntegrazioneException("WSAFrom Value is not valid (NomeSoggetto non identificabile): "+WSA_FROM_FORMAT);
  278.         }
  279.         
  280.         if(tipoSoggetto.contains(".")){
  281.             String[] split = tipoSoggetto.split("\\.");
  282.             tipoSoggetto = split[1];
  283.             String sa = split[0];
  284.             if(tipoSoggetto==null){
  285.                 throw new HeaderIntegrazioneException("WSAFrom Value is not valid (TipoSoggetto non identificabile dopo parsing ServizioApplicativo): "+WSA_FROM_FORMAT);
  286.             }   
  287.             if(sa==null){
  288.                 throw new HeaderIntegrazioneException("WSAFrom Value is not valid (ServizioApplicativo non identificabile): "+WSA_FROM_FORMAT);
  289.             }
  290.             tipoSoggetto = tipoSoggetto.trim();
  291.             sa = sa.trim();
  292.             integrazione.setServizioApplicativo(sa);
  293.         }
  294.         
  295.         integrazione.getBusta().setTipoMittente(tipoSoggetto);
  296.         integrazione.getBusta().setMittente(nomeSoggetto);
  297.     }
  298.     public static String buildDatiWSAFrom(String servizioApplicativoFruitore,String tipoSoggetto,String nomeSoggetto){
  299.         if(servizioApplicativoFruitore==null)
  300.             return "http://"+tipoSoggetto+"_"+nomeSoggetto+".govway.org";
  301.         else
  302.             return "http://"+servizioApplicativoFruitore+"."+tipoSoggetto+"_"+nomeSoggetto+".govway.org";
  303.     }
  304.     public static SOAPHeaderElement buildWSAFrom(OpenSPCoop2SoapMessage msg,String actor,String servizioApplicativoFruitore,String tipoSoggetto,String nomeSoggetto) throws Exception{
  305.         return WSAddressingUtilities.buildWSAFrom(msg, actor, MUST_UNDERSTAND,
  306.                 UtilitiesIntegrazioneWSAddressing.buildDatiWSAFrom(servizioApplicativoFruitore,tipoSoggetto,nomeSoggetto));
  307.     }
  308.     
  309.     
  310.     public static void readDatiWSAAction(String wsaAction,HeaderIntegrazione integrazione) throws HeaderIntegrazioneException{  
  311.         _readDatiWSAToOrAction(wsaAction, WSA_ACTION_FORMAT, integrazione);
  312.     }
  313.     public static String buildDatiWSAAction(String tipoSoggettoErogatore,String nomeSoggettoErogatore,String tipoServizio,String nomeServizio,Integer versioneServizio,String azione){
  314.         return "http://"+tipoSoggettoErogatore+"_"+nomeSoggettoErogatore+".govway.org/services/"+tipoServizio+"_"+nomeServizio+"/"+versioneServizio+"/"+azione;
  315.     }
  316.     public static SOAPHeaderElement buildWSAAction(OpenSPCoop2SoapMessage msg,String actor,String tipoSoggettoErogatore,String nomeSoggettoErogatore,String tipoServizio,String nomeServizio,Integer versioneServizio,String azione) throws Exception{
  317.         return WSAddressingUtilities.buildWSAAction(msg, actor, MUST_UNDERSTAND,
  318.                 UtilitiesIntegrazioneWSAddressing.buildDatiWSAAction(tipoSoggettoErogatore,nomeSoggettoErogatore,tipoServizio,nomeServizio,versioneServizio,azione));
  319.     }
  320.     
  321.     
  322.     public static void readDatiWSAID(String wsaID,HeaderIntegrazione integrazione,boolean interpretaComeIDBusta) throws HeaderIntegrazioneException{
  323.         if(wsaID==null)
  324.             throw new HeaderIntegrazioneException("WSAID value is null");
  325.         wsaID = wsaID.trim();
  326.         if(wsaID.startsWith("uuid:")==false)
  327.             throw new HeaderIntegrazioneException("WSAID Value is not valid: "+WSA_ID_FORMAT);
  328.         
  329.         wsaID = wsaID.substring(5, wsaID.length());
  330.         
  331.         if(interpretaComeIDBusta){
  332.             integrazione.getBusta().setID(wsaID);
  333.         }else{
  334.             integrazione.setIdApplicativo(wsaID);
  335.         }
  336.     }
  337.     public static String buildDatiWSAID(String id){
  338.         return "uuid:"+id;
  339.     }
  340.     public static SOAPHeaderElement buildWSAID(OpenSPCoop2SoapMessage msg,String actor,String wsaID) throws Exception{
  341.         return WSAddressingUtilities.buildWSAID(msg, actor, MUST_UNDERSTAND,
  342.                 UtilitiesIntegrazioneWSAddressing.buildDatiWSAID(wsaID));
  343.     }
  344.     
  345.     
  346.     public static void readDatiWSARelatesTo(String wsaRelatesTo,HeaderIntegrazione integrazione) throws HeaderIntegrazioneException{
  347.         if(wsaRelatesTo==null)
  348.             throw new HeaderIntegrazioneException("WSARelatesTo value is null");
  349.         wsaRelatesTo = wsaRelatesTo.trim();
  350.         if(wsaRelatesTo.startsWith("uuid:")==false)
  351.             throw new HeaderIntegrazioneException("WSARelatesTo Value is not valid: "+WSA_RELATES_TO_FORMAT);
  352.         
  353.         wsaRelatesTo = wsaRelatesTo.substring(5, wsaRelatesTo.length());
  354.         
  355.         integrazione.getBusta().setRiferimentoMessaggio(wsaRelatesTo);
  356.         
  357.     }
  358.     public static String buildDatiWSARelatesTo(String id){
  359.         return "uuid:"+id;
  360.     }
  361.     public static SOAPHeaderElement buildWSARelatesTo(OpenSPCoop2SoapMessage msg,String actor, String id) throws Exception{
  362.         return WSAddressingUtilities.buildWSARelatesTo(msg, actor, MUST_UNDERSTAND,
  363.                 UtilitiesIntegrazioneWSAddressing.buildDatiWSARelatesTo(id));
  364.     }

  366.     
  367.     
  368.     private static UtilitiesIntegrazioneWSAddressing utilitiesIntegrazione = null;
  369.     public static UtilitiesIntegrazioneWSAddressing getInstance(Logger log){
  370.         if(UtilitiesIntegrazioneWSAddressing.utilitiesIntegrazione==null){
  371.             // spotbugs warning 'SING_SINGLETON_GETTER_NOT_SYNCHRONIZED': l'istanza viene creata allo startup
  372.             synchronized (UtilitiesIntegrazioneWSAddressing.class) {
  373.                 UtilitiesIntegrazioneWSAddressing.initialize(log);
  374.             }
  375.         }
  376.         return UtilitiesIntegrazioneWSAddressing.utilitiesIntegrazione;
  377.     }

  379.     private static synchronized void initialize(Logger log){
  380.         if(UtilitiesIntegrazioneWSAddressing.utilitiesIntegrazione==null){
  381.             UtilitiesIntegrazioneWSAddressing.utilitiesIntegrazione = new UtilitiesIntegrazioneWSAddressing(log);
  382.         }
  383.     }


  386.     
  387.     
  388.     
  389.     
  390.     // ***** INSTANCE *****
  391.     
  392.     private UtilitiesIntegrazioneWSAddressing(Logger log){
  393.         if(log!=null) {
  394.             // unused
  395.         }
  396.     }
  397.     
  398.     public void readHeader(OpenSPCoop2SoapMessage message,HeaderIntegrazione integrazione,
  399.             boolean interpretaIDComeIDBusta,String actorIntegrazione) throws HeaderIntegrazioneException{

  401.         try{

  403.             if(actorIntegrazione==null)
  404.                 throw new Exception("Actor non definito");
  405.             
  406.             Logger log = OpenSPCoop2Logger.getLoggerOpenSPCoopCore();
  407.             
  408.             SOAPHeader header = message.getSOAPHeader();
  409.             if(header==null){
  410.                 OpenSPCoop2Logger.getLoggerOpenSPCoopCore().debug("SOAPHeader non presente");
  411.                 return;
  412.             }
  413.             
  414.             SOAPHeaderElement wsaTO = null; 
  415.             SOAPHeaderElement wsaFROM = null; 
  416.             SOAPHeaderElement wsaAction = null; 
  417.             SOAPHeaderElement wsaID = null; 
  418.             SOAPHeaderElement wsaRelatesTo = null; 
  419.             
  420.             WSAddressingUtilities wsaddressingUtilities = new WSAddressingUtilities(log);
  421.             WSAddressingHeader hdrReaded = wsaddressingUtilities.read(message, actorIntegrazione, false);
  422.             if(hdrReaded!=null) {
  423.                 wsaTO = hdrReaded.getTo();
  424.                 wsaFROM = hdrReaded.getFrom();
  425.                 wsaAction = hdrReaded.getAction();
  426.                 wsaID = hdrReaded.getId();
  427.                 wsaRelatesTo = hdrReaded.getRelatesTo();
  428.             }
  429.             if(wsaTO==null && wsaFROM==null  &&  wsaAction==null && wsaID==null  &&  wsaRelatesTo==null){
  430.                 log.debug("Header di integrazione non presente");
  431.                 return;
  432.             }
  433.             
  434.             // ValidazioneXSD
  435.             log.debug("Validazione XSD...");
  436.             wsaddressingUtilities.validate(message, hdrReaded);
  437.             log.debug("Validazione XSD effettuate");
  438.             
  439.             // delete
  440.             if(wsaTO!=null){
  441.                 log.debug("Read dati da WSATo...");
  442.                 UtilitiesIntegrazioneWSAddressing.readDatiWSATo(hdrReaded.getToValue(), integrazione);
  443.             }
  444.             if(wsaFROM!=null){
  445.                 log.debug("Read dati da WSAFrom...");
  446.                 UtilitiesIntegrazioneWSAddressing.readDatiWSAFrom(hdrReaded.getFromValue(), integrazione);
  447.             }
  448.             if(wsaAction!=null){
  449.                 log.debug("Read dati da WSAAction...");
  450.                 UtilitiesIntegrazioneWSAddressing.readDatiWSAAction(hdrReaded.getActionValue(), integrazione);
  451.             }
  452.             if(wsaID!=null){
  453.                 log.debug("Read dati da WSAId...");
  454.                 UtilitiesIntegrazioneWSAddressing.readDatiWSAID(hdrReaded.getIdValue(), integrazione, interpretaIDComeIDBusta);
  455.             }   
  456.             if(wsaRelatesTo!=null){
  457.                 log.debug("Read dati da WSARelatesTo...");
  458.                 UtilitiesIntegrazioneWSAddressing.readDatiWSARelatesTo(hdrReaded.getRelatesToValue(), integrazione);
  459.             }
  460.         
  461.         }catch(Exception e){
  462.             throw new HeaderIntegrazioneException("UtilitiesIntegrazione, lettura dell'header soap non riuscita: "+e.getMessage(),e);
  463.         }
  464.     }
  465.     
  466.     
  467.     public void updateHeader(OpenSPCoop2SoapMessage message,IDSoggetto soggettoFruitore,IDServizio idServizio,
  468.             String idBusta,String servizioApplicativo,
  469.             String correlazioneApplicativa, String idTransazione,String actorIntegrazione) throws Exception{
  470.         updateHeader(message, soggettoFruitore, idServizio, idBusta, null, 
  471.                 servizioApplicativo, correlazioneApplicativa, idTransazione, actorIntegrazione);
  472.     }
  473.     public void updateHeader(OpenSPCoop2SoapMessage message,IDSoggetto soggettoFruitore,IDServizio idServizio,
  474.             String idBusta,String idBustaRisposta,String servizioApplicativo,
  475.             String correlazioneApplicativa, String idTransazione,String actorIntegrazione) throws Exception{
  476.         
  477.         HeaderIntegrazione integrazione = new HeaderIntegrazione(idTransazione);
  478.         integrazione.setIdApplicativo(correlazioneApplicativa);
  479.         integrazione.setServizioApplicativo(servizioApplicativo);
  480.         HeaderIntegrazioneBusta busta = new HeaderIntegrazioneBusta();
  481.         busta.setTipoMittente(soggettoFruitore.getTipo());
  482.         busta.setMittente(soggettoFruitore.getNome());
  483.         busta.setTipoDestinatario(idServizio.getSoggettoErogatore().getTipo());
  484.         busta.setDestinatario(idServizio.getSoggettoErogatore().getNome());
  485.         busta.setTipoServizio(idServizio.getTipo());
  486.         busta.setServizio(idServizio.getNome());
  487.         busta.setVersioneServizio(idServizio.getVersione());
  488.         busta.setAzione(idServizio.getAzione());
  489.         if(idBustaRisposta==null){
  490.             busta.setID(idBusta);
  491.         }
  492.         else{
  493.             busta.setID(idBustaRisposta);
  494.             busta.setRiferimentoMessaggio(idBusta);
  495.         }
  496.         integrazione.setBusta(busta);
  497.         
  498.         this.updateHeader(message, integrazione, actorIntegrazione);
  499.     }
  500.         
  501.     public void updateHeader(OpenSPCoop2SoapMessage message,HeaderIntegrazione integrazione,String actorIntegrazione) throws Exception{
  502.         
  503.         SOAPHeader header = message.getSOAPHeader();
  504.         
  505.         SOAPHeaderElement wsaTO = null; 
  506.         SOAPHeaderElement wsaFROM = null; 
  507.         SOAPHeaderElement wsaAction = null; 
  508.         SOAPHeaderElement wsaID = null; 
  509.         SOAPHeaderElement wsaRelatesTo = null; 
  510.         
  511.         Logger log = OpenSPCoop2Logger.getLoggerOpenSPCoopCore();
  512.         
  513.         if(header==null){
  514.             
  515.             // Creo soap header
  516.             OpenSPCoop2Logger.getLoggerOpenSPCoopCore().debug("SOAPHeader non presente: add soapHeader");
  517.             header = message.getSOAPPart().getEnvelope().addHeader();
  518.             
  519.         }else{

  521.             // cerco soap di integrazione
  522.             
  523.             WSAddressingUtilities wsaddressingUtilities = new WSAddressingUtilities(log);
  524.             WSAddressingHeader hdrReaded = wsaddressingUtilities.read(message, actorIntegrazione, false);
  525.             if(hdrReaded!=null) {
  526.                 wsaTO = hdrReaded.getTo();
  527.                 wsaFROM = hdrReaded.getFrom();
  528.                 wsaAction = hdrReaded.getAction();
  529.                 wsaID = hdrReaded.getId();
  530.                 wsaRelatesTo = hdrReaded.getRelatesTo();
  531.             }
  532.             
  533.         }

  535.         if(integrazione.getBusta()!=null){
  536.             
  537.             HeaderIntegrazioneBusta hBusta = integrazione.getBusta();
  538.                 
  539.             if(hBusta.getDestinatario()!=null && hBusta.getServizio()!=null){
  540.                 
  541.                 // To
  542.                 if(wsaTO!=null){
  543.                     // aggiorno
  544.                     wsaTO.setValue(UtilitiesIntegrazioneWSAddressing.buildDatiWSATo(hBusta.getTipoDestinatario(), hBusta.getDestinatario(), 
  545.                             hBusta.getTipoServizio() , hBusta.getServizio(), hBusta.getVersioneServizio()));
  546.                 }
  547.                 else{
  548.                     wsaTO = UtilitiesIntegrazioneWSAddressing.buildWSATo(message,actorIntegrazione,hBusta.getTipoDestinatario(), hBusta.getDestinatario(), 
  549.                             hBusta.getTipoServizio() , hBusta.getServizio(), hBusta.getVersioneServizio());
  550.                     //header.addChildElement(wsaTO);
  551.                     message.addHeaderElement(header, wsaTO);
  552.                 }
  553.                 
  554.                 
  555.                 // Action
  556.                 if(hBusta.getAzione()!=null){
  557.                     if(wsaAction!=null){
  558.                         // aggiorno
  559.                         wsaAction.setValue(UtilitiesIntegrazioneWSAddressing.buildDatiWSAAction(hBusta.getTipoDestinatario(), hBusta.getDestinatario(), 
  560.                                 hBusta.getTipoServizio() , hBusta.getServizio(), hBusta.getVersioneServizio(), hBusta.getAzione()));
  561.                     }
  562.                     else{
  563.                         wsaAction = UtilitiesIntegrazioneWSAddressing.buildWSAAction(message,actorIntegrazione,hBusta.getTipoDestinatario(), hBusta.getDestinatario(), 
  564.                                 hBusta.getTipoServizio() , hBusta.getServizio(), hBusta.getVersioneServizio(), hBusta.getAzione());
  565.                         //header.addChildElement(wsaTO);
  566.                         message.addHeaderElement(header, wsaTO);
  567.                     }
  568.                 }
  569.             }
  570.             
  571.             if(hBusta.getMittente()!=null){
  572.                 if(wsaFROM!=null){
  573.                     // aggiorno
  574.                     Iterator<?> itFROM = wsaFROM.getChildElements();
  575.                     while (itFROM.hasNext()) {
  576.                         Object o = itFROM.next();
  577.                         if(o!=null && (o instanceof SOAPElement) ){
  578.                             SOAPElement s = (SOAPElement) o;
  579.                             if(Costanti.WSA_SOAP_HEADER_EPR_ADDRESS.equals(s.getLocalName())){
  580.                                 s.setValue(buildDatiWSAFrom(integrazione.getServizioApplicativo(),hBusta.getTipoMittente(),hBusta.getMittente()));
  581.                                 break;
  582.                             }
  583.                         }
  584.                     }
  585.                 }
  586.                 else{
  587.                     wsaFROM = UtilitiesIntegrazioneWSAddressing.buildWSAFrom(message,actorIntegrazione,integrazione.getServizioApplicativo(),hBusta.getTipoMittente(),hBusta.getMittente());
  588.                     //header.addChildElement(wsaFROM);
  589.                     message.addHeaderElement(header, wsaFROM);
  590.                 }
  591.             }
  592.                 
  593.             if(hBusta.getID()!=null){
  594.                 if(wsaID!=null){
  595.                     // aggiorno
  596.                     wsaID.setValue(UtilitiesIntegrazioneWSAddressing.buildDatiWSAID(hBusta.getID()));
  597.                 }
  598.                 else{
  599.                     wsaID = UtilitiesIntegrazioneWSAddressing.buildWSAID(message,actorIntegrazione,hBusta.getID());
  600.                     //header.addChildElement(wsaID);
  601.                     message.addHeaderElement(header, wsaID);
  602.                 }
  603.             }
  604.             
  605.             if(hBusta.getRiferimentoMessaggio()!=null || hBusta.getIdCollaborazione()!=null){
  606.                 String rif = hBusta.getRiferimentoMessaggio();
  607.                 if(rif==null){
  608.                     rif = hBusta.getIdCollaborazione();
  609.                 }
  610.                 if(wsaRelatesTo!=null){
  611.                     // aggiorno
  612.                     wsaRelatesTo.setValue(UtilitiesIntegrazioneWSAddressing.buildDatiWSARelatesTo(rif));
  613.                 }
  614.                 else{
  615.                     wsaRelatesTo = UtilitiesIntegrazioneWSAddressing.buildWSARelatesTo(message,actorIntegrazione,rif);
  616.                     //header.addChildElement(wsaRelatesTo);
  617.                     message.addHeaderElement(header, wsaRelatesTo);
  618.                 }
  619.             }
  620.         }
  621.     }

  623.     
  624.     public void deleteHeader(OpenSPCoop2SoapMessage message,String actorIntegrazione) throws HeaderIntegrazioneException{

  626.         try{

  628.             if(actorIntegrazione==null)
  629.                 throw new Exception("Actor non definito");
  630.             
  631.             Logger log = OpenSPCoop2Logger.getLoggerOpenSPCoopCore();
  632.             
  633.             SOAPHeader header = message.getSOAPHeader();
  634.             if(header==null){
  635.                 OpenSPCoop2Logger.getLoggerOpenSPCoopCore().debug("SOAPHeader non presente");
  636.                 return;
  637.             }
  638.             
  639.             WSAddressingUtilities wsaddressingUtilities = new WSAddressingUtilities(log);
  640.             wsaddressingUtilities.delete(message, actorIntegrazione);
  641.         
  642.         }catch(Exception e){
  643.             throw new HeaderIntegrazioneException("UtilitiesIntegrazione, lettura dell'header soap non riuscita: "+e.getMessage(),e);
  644.         }
  645.     }
  646. }
Created with JaCoCo 0.8.8.202204050719