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




  24. package org.openspcoop2.core.registry.driver.uddi;

  26. import java.io.ByteArrayInputStream;
  27. import java.util.ArrayList;
  28. import java.util.List;

  30. import org.openspcoop2.core.commons.CoreException;
  31. import org.openspcoop2.core.commons.Filtri;
  32. import org.openspcoop2.core.commons.IDriverWS;
  33. import org.openspcoop2.core.commons.IMonitoraggioRisorsa;
  34. import org.openspcoop2.core.id.IDAccordo;
  35. import org.openspcoop2.core.id.IDAccordoAzione;
  36. import org.openspcoop2.core.id.IDAccordoCooperazione;
  37. import org.openspcoop2.core.id.IDFruizione;
  38. import org.openspcoop2.core.id.IDGruppo;
  39. import org.openspcoop2.core.id.IDPortType;
  40. import org.openspcoop2.core.id.IDPortTypeAzione;
  41. import org.openspcoop2.core.id.IDResource;
  42. import org.openspcoop2.core.id.IDRuolo;
  43. import org.openspcoop2.core.id.IDScope;
  44. import org.openspcoop2.core.id.IDServizio;
  45. import org.openspcoop2.core.id.IDSoggetto;
  46. import org.openspcoop2.core.registry.AccordoCooperazione;
  47. import org.openspcoop2.core.registry.AccordoServizioParteComune;
  48. import org.openspcoop2.core.registry.AccordoServizioParteSpecifica;
  49. import org.openspcoop2.core.registry.Azione;
  50. import org.openspcoop2.core.registry.ConfigurazioneServizioAzione;
  51. import org.openspcoop2.core.registry.CredenzialiSoggetto;
  52. import org.openspcoop2.core.registry.Documento;
  53. import org.openspcoop2.core.registry.Fruitore;
  54. import org.openspcoop2.core.registry.Gruppo;
  55. import org.openspcoop2.core.registry.GruppoAccordo;
  56. import org.openspcoop2.core.registry.Operation;
  57. import org.openspcoop2.core.registry.PortType;
  58. import org.openspcoop2.core.registry.PortaDominio;
  59. import org.openspcoop2.core.registry.Resource;
  60. import org.openspcoop2.core.registry.Ruolo;
  61. import org.openspcoop2.core.registry.Scope;
  62. import org.openspcoop2.core.registry.Soggetto;
  63. import org.openspcoop2.core.registry.constants.CostantiRegistroServizi;
  64. import org.openspcoop2.core.registry.constants.CostantiXMLRepository;
  65. import org.openspcoop2.core.registry.constants.CredenzialeTipo;
  66. import org.openspcoop2.core.registry.constants.RuoloContesto;
  67. import org.openspcoop2.core.registry.constants.RuoloTipologia;
  68. import org.openspcoop2.core.registry.constants.ScopeContesto;
  69. import org.openspcoop2.core.registry.constants.TipiDocumentoLivelloServizio;
  70. import org.openspcoop2.core.registry.constants.TipiDocumentoSemiformale;
  71. import org.openspcoop2.core.registry.constants.TipiDocumentoSicurezza;
  72. import org.openspcoop2.core.registry.driver.BeanUtilities;
  73. import org.openspcoop2.core.registry.driver.DriverRegistroServiziException;
  74. import org.openspcoop2.core.registry.driver.DriverRegistroServiziNotFound;
  75. import org.openspcoop2.core.registry.driver.FiltroRicerca;
  76. import org.openspcoop2.core.registry.driver.FiltroRicercaAccordi;
  77. import org.openspcoop2.core.registry.driver.FiltroRicercaAzioni;
  78. import org.openspcoop2.core.registry.driver.FiltroRicercaFruizioniServizio;
  79. import org.openspcoop2.core.registry.driver.FiltroRicercaGruppi;
  80. import org.openspcoop2.core.registry.driver.FiltroRicercaOperations;
  81. import org.openspcoop2.core.registry.driver.FiltroRicercaPortTypes;
  82. import org.openspcoop2.core.registry.driver.FiltroRicercaResources;
  83. import org.openspcoop2.core.registry.driver.FiltroRicercaRuoli;
  84. import org.openspcoop2.core.registry.driver.FiltroRicercaScope;
  85. import org.openspcoop2.core.registry.driver.FiltroRicercaServizi;
  86. import org.openspcoop2.core.registry.driver.FiltroRicercaSoggetti;
  87. import org.openspcoop2.core.registry.driver.IDAccordoCooperazioneFactory;
  88. import org.openspcoop2.core.registry.driver.IDAccordoFactory;
  89. import org.openspcoop2.core.registry.driver.IDServizioFactory;
  90. import org.openspcoop2.core.registry.driver.IDriverRegistroServiziCRUD;
  91. import org.openspcoop2.core.registry.driver.IDriverRegistroServiziGet;
  92. import org.openspcoop2.core.registry.driver.ProtocolPropertiesUtilities;
  93. import org.openspcoop2.core.registry.driver.web.XMLLib;
  94. import org.openspcoop2.message.OpenSPCoop2MessageFactory;
  95. import org.openspcoop2.message.xml.ValidatoreXSD;
  96. import org.openspcoop2.utils.LoggerWrapperFactory;
  97. import org.openspcoop2.utils.UtilsException;
  98. import org.openspcoop2.utils.UtilsRuntimeException;
  99. import org.openspcoop2.utils.certificate.ArchiveLoader;
  100. import org.openspcoop2.utils.certificate.ArchiveType;
  101. import org.openspcoop2.utils.certificate.Certificate;
  102. import org.openspcoop2.utils.certificate.CertificateInfo;
  103. import org.openspcoop2.utils.certificate.CertificateUtils;
  104. import org.openspcoop2.utils.certificate.PrincipalType;
  105. import org.openspcoop2.utils.crypt.CryptConfig;
  106. import org.openspcoop2.utils.crypt.CryptFactory;
  107. import org.openspcoop2.utils.crypt.ICrypt;
  108. import org.openspcoop2.utils.transport.http.HttpUtilities;
  109. import org.slf4j.Logger;

  111. /**
  112.  * Classe utilizzata per effettuare query al registro UDDI, riguardanti specifiche
  113.  * proprieta' di servizi presenti all'interno del registro.
  114.  *
  115.  *
  116.  * @author Anedda Valentino (anedda@link.it)
  117.  * @author Poli Andrea (apoli@link.it)
  118.  * @author $Author$
  119.  * @version $Rev$, $Date$
  120.  */

  122. public class DriverRegistroServiziUDDI extends BeanUtilities
  123.    implements IDriverRegistroServiziGet,IDriverRegistroServiziCRUD, IDriverWS,IMonitoraggioRisorsa{


  126.    
  127.     /* ********  F I E L D S  P R I V A T I  ******** */

  129.     /** Indicazione di una corretta creazione */
  130.     public boolean create = false;

  132.     /** UDDI Lib. */
  133.     private UDDILib uddiLib=null;
  134.     /** --- URL Prefix utilizzato come prefisso da associare alle url memorizzate nelle entita create nell'UDDI
  135.     e contenenti le definizioni XML ------*/
  136.     private String urlPrefix;   
  137.     /** --- Utility per la generazione dell'XML ------*/
  138.     private XMLLib generatoreXML;
  139.     
  140.     /** Validatore della configurazione */
  141.     private ValidatoreXSD validatoreRegistro = null;
  142.     
  143.     /** Logger utilizzato per info. */
  144.     private org.slf4j.Logger log = null;

  146.     // Factory
  147.     private IDAccordoFactory idAccordoFactory = IDAccordoFactory.getInstance();
  148.     private IDAccordoCooperazioneFactory idAccordoCooperazioneFactory = IDAccordoCooperazioneFactory.getInstance();
  149.     private IDServizioFactory idServizioFactory = IDServizioFactory.getInstance();


  152.     /* ********  C O S T R U T T O R E  ******** */
  153.     /**
  154.      * Costruttore per Query senza autenticazione. 
  155.      *
  156.      * 
  157.      */
  158.     public DriverRegistroServiziUDDI(String inquiry,Logger alog){
  159.         this(inquiry,null,null,alog);
  160.     }
  161.     /**
  162.      * Costruttore per Query con autenticazione. 
  163.      *
  164.      * 
  165.      */
  166.     public DriverRegistroServiziUDDI(String inquiry,String user,String password,Logger alog){   
  167.         this(inquiry,null,user,password,null,null,alog);
  168.     }

  170.     /**
  171.      * Costruttore per Gestione senza autenticazione. 
  172.      *
  173.      * 
  174.      */
  175.     public DriverRegistroServiziUDDI(String inquiry,String publish, String urlPrefix, String pathPrefix,Logger alog){
  176.         this(inquiry,publish,null,null,urlPrefix,pathPrefix,alog);
  177.     }
  178.     /**
  179.      * Costruttore per Gestione con autenticazione. 
  180.      *
  181.      * 
  182.      */
  183.     public DriverRegistroServiziUDDI(String inquiry,String publish, String user,String password,String urlPrefix, String pathPrefix,Logger alog){

  185.         if(alog==null)
  186.             this.log = LoggerWrapperFactory.getLogger(DriverRegistroServiziUDDI.class);
  187.         else
  188.             this.log = alog;
  189.         if(this.log==null) {
  190.             throw new UtilsRuntimeException("Logger unavailable");
  191.         }
  192.         try{
  193.             
  194.             if(publish!=null){
  195.                 this.uddiLib=new UDDILib(inquiry,publish,user,password);
  196.             }else{
  197.                 if(user!=null && password!=null){
  198.                     this.uddiLib=new UDDILib(inquiry,user,password);
  199.                 }else{
  200.                     this.uddiLib=new UDDILib(inquiry);
  201.                 }
  202.             }

  204.             /* --- Costruzione Validatore XSD -- */
  205.             try{
  206.                 this.validatoreRegistro = new ValidatoreXSD(OpenSPCoop2MessageFactory.getDefaultMessageFactory(), this.log,DriverRegistroServiziUDDI.class.getResourceAsStream("/registroServizi.xsd"));
  207.             }catch (Exception e) {
  208.                 throw new Exception("Riscontrato errore durante l'inizializzazione dello schema del Registro dei Servizi di OpenSPCoop: "+e.getMessage(),e);
  209.             }
  210.             
  211.             if(urlPrefix!=null){
  212.                 if (!urlPrefix.endsWith(CostantiRegistroServizi.URL_SEPARATOR))
  213.                     this.urlPrefix= urlPrefix + CostantiRegistroServizi.URL_SEPARATOR;
  214.                 else
  215.                     this.urlPrefix = urlPrefix;
  216.             }
  217.             if(urlPrefix!=null && pathPrefix!=null){
  218.                 this.generatoreXML = new XMLLib(pathPrefix,urlPrefix);
  219.             }
  220.             
  221.             this.create = this.uddiLib.create;
  222.         }catch(Exception e){
  223.             this.log.error("Inizializzazione fallita: "+e.getMessage(),e);
  224.             this.create = false;
  225.         }
  226.     }





  232.     
  233.     /* ********  INTERFACCIA IDriverRegistroServiziGet ******** */ 
  234.     
  235.     
  236.     /* Accordi di Cooperazione */
  237.     
  238.     /**
  239.      * Si occupa di ritornare l'oggetto {@link org.openspcoop2.core.registry.AccordoCooperazione}, 
  240.      * identificato grazie al parametro 
  241.      * <var>nomeAccordo</var> 
  242.      *
  243.      * @param idAccordo Identificativo dell'accordo di Cooperazione
  244.      * @return un oggetto di tipo {@link org.openspcoop2.core.registry.AccordoCooperazione}.
  245.      * 
  246.      */
  247.     @Override
  248.     public org.openspcoop2.core.registry.AccordoCooperazione getAccordoCooperazione(IDAccordoCooperazione idAccordo) throws DriverRegistroServiziException,DriverRegistroServiziNotFound{

  250.         if( idAccordo == null)
  251.             throw new DriverRegistroServiziException("[AccordoCooperazione] Parametro Non Valido");
  252.         if( idAccordo.getNome() == null)
  253.             throw new DriverRegistroServiziException("[AccordoCooperazione] Nome accordo servizio non fornito");
  254.         
  255.         //       controllo inizializzazione UDDI
  256.         if(this.uddiLib.create == false){
  257.             throw new DriverRegistroServiziException("[AccordoCooperazione] Inizializzazione dell'engine UDDI errata");
  258.         }
  259.         
  260.         //       Controllo pre-esistenza dell'accordo
  261.         if( this.uddiLib.existsAccordoCooperazione(idAccordo) == false){
  262.             throw new DriverRegistroServiziNotFound("[AccordoCooperazione] Accordo richiesto non esiste: "+idAccordo);
  263.         } 
  264.         
  265.         org.openspcoop2.core.registry.AccordoCooperazione accRichiesto = null;

  267.         // Ottengo URL XML associato all'accordo
  268.         String urlXMLAccordoCooperazione = this.uddiLib.getUrlXmlAccordoCooperazione(idAccordo);
  269.         if(urlXMLAccordoCooperazione == null){
  270.             throw new DriverRegistroServiziException("[AccordoCooperazione] definzione XML non disponibile");
  271.         }

  273.         // Ottengo oggetto AccordoCooperazione
  274.         ByteArrayInputStream bin = null;
  275.         try{
  276.             byte[] fileXML = null;
  277.             try{
  278.                 fileXML = HttpUtilities.requestHTTPFile(urlXMLAccordoCooperazione);
  279.             }catch(UtilsException e){
  280.                 // Controllo pre-esistenza dell'accordo
  281.                 if( "404".equals(e.getMessage()) ){
  282.                     throw new DriverRegistroServiziNotFound("[AccordoCooperazione] Accordo richiesto non esiste nel repository http: "+idAccordo);
  283.                 } else
  284.                     throw e;
  285.             }
  286.             
  287.             /* --- Validazione XSD (ora che sono sicuro che non ho un 404) -- */
  288.             try{
  289.                 this.validatoreRegistro.valida(urlXMLAccordoCooperazione);  
  290.             }catch (Exception e) {
  291.                 throw new DriverRegistroServiziException("[AccordoCooperazione] Riscontrato errore durante la validazione XSD Accordo("+idAccordo+"): "+e.getMessage(),e);
  292.             }
  293.             
  294.             // parsing
  295.             bin = new ByteArrayInputStream(fileXML);
  296.             org.openspcoop2.core.registry.utils.serializer.JaxbDeserializer deserializer = new org.openspcoop2.core.registry.utils.serializer.JaxbDeserializer();
  297.             org.openspcoop2.core.registry.RegistroServizi rs = 
  298.                 (org.openspcoop2.core.registry.RegistroServizi) deserializer.readRegistroServizi(bin);
  299.             if(rs.sizeAccordoCooperazioneList()>0)
  300.                 accRichiesto = rs.getAccordoCooperazione(0);
  301.             bin.close();
  302.         }catch(Exception e){
  303.             try{
  304.                 if(bin!=null)
  305.                     bin.close();
  306.             } catch(Exception eis) {
  307.                 // ignore
  308.             }
  309.             if(e instanceof DriverRegistroServiziNotFound)
  310.                 throw (DriverRegistroServiziNotFound)e;
  311.             else
  312.                 throw new DriverRegistroServiziException("[AccordoCooperazione] Errore durante il parsing xml Accordo("+idAccordo+"): "+e.getMessage(),e);
  313.         }

  315.         if(accRichiesto==null)
  316.             throw new DriverRegistroServiziNotFound("[AccordoCooperazione] Accordo di Cooperazione ["+idAccordo+"] non trovato.");
  317.         
  318.         return accRichiesto;
  319.     }

  321.     /**
  322.      * Ritorna gli identificatori degli accordi che rispettano il parametro di ricerca
  323.      * 
  324.      * @param filtroRicerca
  325.      * @return Una lista di ID degli accordi trovati
  326.      * @throws DriverRegistroServiziException
  327.      * @throws DriverRegistroServiziNotFound
  328.      */
  329.     @Override
  330.     public List<IDAccordoCooperazione> getAllIdAccordiCooperazione(FiltroRicercaAccordi filtroRicerca) throws DriverRegistroServiziException,DriverRegistroServiziNotFound{
  331.         try{

  333.             // Ricerca UDDI degli accordi
  334.             /*if(this.urlPrefix==null){
  335.                 throw new DriverRegistroServiziException("[getAllIdAccordiCooperazione] Implementazione non eseguibile se il driver non viene inizializzato con urlPrefix.");
  336.             }*/
  337.             
  338.             IDAccordoCooperazione idAccordoFiltro = null;
  339.             if(filtroRicerca!=null && filtroRicerca.getNomeAccordo()!=null){
  340.                 IDSoggetto soggettoReferente = null;
  341.                 if(filtroRicerca.getTipoSoggettoReferente()!=null && filtroRicerca.getNomeSoggettoReferente()!=null){
  342.                     soggettoReferente = new IDSoggetto(filtroRicerca.getTipoSoggettoReferente(), filtroRicerca.getNomeSoggettoReferente());
  343.                 }
  344.                 idAccordoFiltro = this.idAccordoCooperazioneFactory.getIDAccordoFromValues(filtroRicerca.getNomeAccordo(),soggettoReferente,filtroRicerca.getVersione());
  345.             }
  346.             
  347.             String [] urlXMLAccordi = this.uddiLib.getUrlXmlAccordiCooperazione(idAccordoFiltro,this.urlPrefix);
  348.             
  349.             // Esamina degli accordi
  350.             List<IDAccordoCooperazione> idAccordi = new ArrayList<IDAccordoCooperazione>();
  351.             for(int i=0; i<urlXMLAccordi.length; i++){
  352.                 org.openspcoop2.core.registry.AccordoCooperazione ac = null;
  353.                 
  354.                 /* --- Validazione XSD -- */
  355.                 try{
  356.                     this.validatoreRegistro.valida(urlXMLAccordi[i]);  
  357.                 }catch (Exception e) {
  358.                     throw new DriverRegistroServiziException("[getAllIdAccordiCooperazione] Riscontrato errore durante la validazione XSD ("+urlXMLAccordi[i]+"): "+e.getMessage(),e);
  359.                 }
  360.                 
  361.                 // Ottengo oggetto Accordo
  362.                 ByteArrayInputStream bin = null;
  363.                 try{
  364.                     byte[] fileXML = HttpUtilities.requestHTTPFile(urlXMLAccordi[i]);
  365.                     bin = new ByteArrayInputStream(fileXML);
  366.                     org.openspcoop2.core.registry.utils.serializer.JaxbDeserializer deserializer = new org.openspcoop2.core.registry.utils.serializer.JaxbDeserializer();
  367.                     org.openspcoop2.core.registry.RegistroServizi rs = 
  368.                         (org.openspcoop2.core.registry.RegistroServizi) deserializer.readRegistroServizi(bin);
  369.                     if(rs.sizeAccordoCooperazioneList()>0)
  370.                         ac = rs.getAccordoCooperazione(0);
  371.                     bin.close();
  372.                 }catch(Exception e){
  373.                     try{
  374.                         if(bin!=null)
  375.                             bin.close();
  376.                     } catch(Exception eis) {
  377.                         // ignore
  378.                     }
  379.                     throw new DriverRegistroServiziException("[getAllIdAccordiCooperazione] Errore durante il parsing xml ("+urlXMLAccordi[i]+"): "+e.getMessage(),e);
  380.                 }
  381.                 if(ac==null)
  382.                     throw new DriverRegistroServiziException("[getAllIdAccordiCooperazione] accordo non definito per la url ["+urlXMLAccordi[i]+"]");
  383.                 String acURI = this.idAccordoCooperazioneFactory.getUriFromAccordo(ac);
  384.                 
  385.                 if(filtroRicerca!=null){
  386.                     // Filtro By Data
  387.                     if(filtroRicerca.getMinDate()!=null){
  388.                         if(ac.getOraRegistrazione()==null){
  389.                             this.log.debug("[getAllIdAccordiCooperazione](FiltroByMinDate) Accordo di cooperazione ["+acURI+"] non valorizzato nell'ora-registrazione. Non inserito nella lista ritornata.");
  390.                             continue;
  391.                         }else if(ac.getOraRegistrazione().before(filtroRicerca.getMinDate())){
  392.                             continue;
  393.                         }
  394.                     }
  395.                     if(filtroRicerca.getMaxDate()!=null){
  396.                         if(ac.getOraRegistrazione()==null){
  397.                             this.log.debug("[getAllIdAccordiCooperazione](FiltroByMaxDate) Accordo di cooperazione ["+acURI+"] non valorizzato nell'ora-registrazione. Non inserito nella lista ritornata.");
  398.                             continue;
  399.                         }else if(ac.getOraRegistrazione().after(filtroRicerca.getMaxDate())){
  400.                             continue;
  401.                         }
  402.                     }
  403.                     // Filtro By Nome
  404.                     if(filtroRicerca.getNomeAccordo()!=null){
  405.                         if(ac.getNome().equals(filtroRicerca.getNomeAccordo()) == false){
  406.                             continue;
  407.                         }
  408.                     }
  409.                     if(filtroRicerca.getVersione()!=null){
  410.                         if(ac.getVersione().equals(filtroRicerca.getVersione()) == false){
  411.                             continue;
  412.                         }
  413.                     }
  414.                     if(filtroRicerca.getTipoSoggettoReferente()!=null || filtroRicerca.getNomeSoggettoReferente()!=null){
  415.                         if(ac.getSoggettoReferente()==null)
  416.                             continue;
  417.                         if(filtroRicerca.getTipoSoggettoReferente()!=null){
  418.                             if(ac.getSoggettoReferente().getTipo().equals(filtroRicerca.getTipoSoggettoReferente()) == false){
  419.                                 continue;
  420.                             }
  421.                         }
  422.                         if(filtroRicerca.getNomeSoggettoReferente()!=null){
  423.                             if(ac.getSoggettoReferente().getNome().equals(filtroRicerca.getNomeSoggettoReferente()) == false){
  424.                                 continue;
  425.                             }
  426.                         }
  427.                     }
  428.                     // ProtocolProperties
  429.                     if(ProtocolPropertiesUtilities.isMatch(ac, filtroRicerca.getProtocolPropertiesAccordo())==false){
  430.                         continue;
  431.                     }
  432.                 }
  433.                 idAccordi.add(this.idAccordoCooperazioneFactory.getIDAccordoFromAccordo(ac));
  434.             }
  435.             if(idAccordi.size()==0){
  436.                 throw new DriverRegistroServiziNotFound("Accordi non trovati che rispettano il filtro di ricerca selezionato: "+filtroRicerca.toString());
  437.             }else{
  438.                 return idAccordi;
  439.             }
  440.         }catch(Exception e){
  441.             if(e instanceof DriverRegistroServiziNotFound)
  442.                 throw (DriverRegistroServiziNotFound)e;
  443.             else
  444.                 throw new DriverRegistroServiziException("getAllIdAccordiCooperazione error",e);
  445.         }
  446.     }
  447.     
  448.     
  449.     
  450.     
  451.     
  452.     
  453.     /* Accordi di Servizio Parte Comune */
  454.     
  455.     /**
  456.      * Si occupa di ritornare l'oggetto {@link org.openspcoop2.core.registry.AccordoServizioParteComune}, 
  457.      * identificato grazie al parametro 
  458.      * <var>nomeAccordo</var> 
  459.      *
  460.      * @param idAccordo Identificativo dell'accordo di Servizio
  461.      * @return un oggetto di tipo {@link org.openspcoop2.core.registry.AccordoServizioParteComune}.
  462.      * 
  463.      */
  464.     @Override
  465.     public org.openspcoop2.core.registry.AccordoServizioParteComune getAccordoServizioParteComune(IDAccordo idAccordo) throws DriverRegistroServiziException,DriverRegistroServiziNotFound{

  467.         if( idAccordo == null)
  468.             throw new DriverRegistroServiziException("[getAccordoServizioParteComune] Parametro Non Valido");
  469.         if( idAccordo.getNome() == null)
  470.             throw new DriverRegistroServiziException("[getAccordoServizioParteComune] Nome accordo servizio non fornito");
  471.         
  472.         //       controllo inizializzazione UDDI
  473.         if(this.uddiLib.create == false){
  474.             throw new DriverRegistroServiziException("[getAccordoServizioParteComune] Inizializzazione dell'engine UDDI errata");
  475.         }
  476.         
  477.         //       Controllo pre-esistenza dell'accordo
  478.         if( this.uddiLib.existsAccordoServizio(idAccordo) == false){
  479.             throw new DriverRegistroServiziNotFound("[getAccordoServizioParteComune] Accordo richiesto non esiste: "+idAccordo);
  480.         } 
  481.         
  482.         org.openspcoop2.core.registry.AccordoServizioParteComune accRichiesto = null;

  484.         // Ottengo URL XML associato all'accordo
  485.         String urlXMLAccordoServizio = this.uddiLib.getUrlXmlAccordoServizio(idAccordo);
  486.         if(urlXMLAccordoServizio == null){
  487.             throw new DriverRegistroServiziException("[getAccordoServizioParteComune] definzione XML non disponibile");
  488.         }

  490.         // Ottengo oggetto AccordoServizio
  491.         ByteArrayInputStream bin = null;
  492.         try{
  493.             byte[] fileXML = null;
  494.             try{
  495.                 fileXML = HttpUtilities.requestHTTPFile(urlXMLAccordoServizio);
  496.             }catch(UtilsException e){
  497.                 // Controllo pre-esistenza dell'accordo
  498.                 if( "404".equals(e.getMessage()) ){
  499.                     throw new DriverRegistroServiziNotFound("[getAccordoServizioParteComune] Accordo richiesto non esiste nel repository http: "+idAccordo);
  500.                 } else
  501.                     throw e;
  502.             }
  503.             
  504.             /* --- Validazione XSD (ora che sono sicuro che non ho un 404) -- */
  505.             try{
  506.                 this.validatoreRegistro.valida(urlXMLAccordoServizio);  
  507.             }catch (Exception e) {
  508.                 throw new DriverRegistroServiziException("[getAccordoServizioParteComune] Riscontrato errore durante la validazione XSD Accordo("+idAccordo+"): "+e.getMessage(),e);
  509.             }
  510.             
  511.             // parsing
  512.             bin = new ByteArrayInputStream(fileXML);
  513.             org.openspcoop2.core.registry.utils.serializer.JaxbDeserializer deserializer = new org.openspcoop2.core.registry.utils.serializer.JaxbDeserializer();
  514.             org.openspcoop2.core.registry.RegistroServizi rs = 
  515.                 (org.openspcoop2.core.registry.RegistroServizi) deserializer.readRegistroServizi(bin);
  516.             if(rs.sizeAccordoServizioParteComuneList()>0)
  517.                 accRichiesto = rs.getAccordoServizioParteComune(0);
  518.             bin.close();
  519.         }catch(Exception e){
  520.             try{
  521.                 if(bin!=null)
  522.                     bin.close();
  523.             } catch(Exception eis) {
  524.                 // ignore
  525.             }
  526.             if(e instanceof DriverRegistroServiziNotFound)
  527.                 throw (DriverRegistroServiziNotFound)e;
  528.             else
  529.                 throw new DriverRegistroServiziException("[getAccordoServizioParteComune] Errore durante il parsing xml Accordo("+idAccordo+"): "+e.getMessage(),e);
  530.         }

  532.         if(accRichiesto==null)
  533.             throw new DriverRegistroServiziNotFound("[getAccordoServizioParteComune] Accordo di Servizio ["+idAccordo+"] non trovato.");
  534.         
  535.         // nomiAzione setting 
  536. //      accRichiesto.setNomiAzione(accRichiesto.readNomiAzione());
  537.         
  538.         return accRichiesto;
  539.     }

  541.     @Override
  542.     public List<IDAccordo> getAllIdAccordiServizioParteComune(FiltroRicercaAccordi filtroRicerca) throws DriverRegistroServiziException,DriverRegistroServiziNotFound{

  544.         List<IDAccordo> list = new ArrayList<IDAccordo>();
  545.         _fillAllIdAccordiServizioParteComuneEngine("getAllIdAccordiServizioParteComune", filtroRicerca, null, null, null, null, list);
  546.         return list;
  547.     
  548.     }
  549.     
  550.     @Override
  551.     public List<IDPortType> getAllIdPortType(FiltroRicercaPortTypes filtroRicerca) throws DriverRegistroServiziException,DriverRegistroServiziNotFound{
  552.         
  553.         List<IDPortType> list = new ArrayList<IDPortType>();
  554.         _fillAllIdAccordiServizioParteComuneEngine("getAllIdPortType", filtroRicerca, filtroRicerca, null, null, null, list);
  555.         return list;
  556.         
  557.     }
  558.     
  559.     @Override
  560.     public List<IDPortTypeAzione> getAllIdAzionePortType(FiltroRicercaOperations filtroRicerca) throws DriverRegistroServiziException,DriverRegistroServiziNotFound{
  561.     
  562.         List<IDPortTypeAzione> list = new ArrayList<IDPortTypeAzione>();
  563.         _fillAllIdAccordiServizioParteComuneEngine("getAllIdAzionePortType", filtroRicerca, null, filtroRicerca, null, null, list);
  564.         return list;
  565.         
  566.     }
  567.     
  568.     @Override
  569.     public List<IDAccordoAzione> getAllIdAzioneAccordo(FiltroRicercaAzioni filtroRicerca) throws DriverRegistroServiziException,DriverRegistroServiziNotFound{
  570.         
  571.         List<IDAccordoAzione> list = new ArrayList<IDAccordoAzione>();
  572.         _fillAllIdAccordiServizioParteComuneEngine("getAllIdAzioneAccordo", filtroRicerca, null, null, filtroRicerca, null, list);
  573.         return list;
  574.         
  575.     }
  576.     
  577.     @Override
  578.     public List<IDResource> getAllIdResource(FiltroRicercaResources filtroRicerca) throws DriverRegistroServiziException,DriverRegistroServiziNotFound{
  579.         
  580.         List<IDResource> list = new ArrayList<IDResource>();
  581.         _fillAllIdAccordiServizioParteComuneEngine("getAllIdResource", filtroRicerca, null, null, null, filtroRicerca, list);
  582.         return list;
  583.         
  584.     }
  585.     
  586.     @SuppressWarnings("unchecked")
  587.     public <T> void _fillAllIdAccordiServizioParteComuneEngine(String nomeMetodo, 
  588.             FiltroRicercaAccordi filtroRicercaBase,
  589.             FiltroRicercaPortTypes filtroPT, FiltroRicercaOperations filtroOP, FiltroRicercaAzioni filtroAZ,
  590.             FiltroRicercaResources filtroResource,
  591.             List<T> listReturn) throws DriverRegistroServiziException,DriverRegistroServiziNotFound{
  592.         try{

  594.             // Ricerca UDDI degli accordi
  595.             /*if(this.urlPrefix==null){
  596.                 throw new DriverRegistroServiziException("[getAllIdAccordiServizio] Implementazione non eseguibile se il driver non viene inizializzato con urlPrefix.");
  597.             }*/
  598.             
  599.             IDAccordo idAccordoFiltro = null;
  600.             if(filtroRicercaBase!=null && filtroRicercaBase.getNomeAccordo()!=null){
  601.                 IDSoggetto soggettoReferente = null;
  602.                 if(filtroRicercaBase.getTipoSoggettoReferente()!=null && filtroRicercaBase.getNomeSoggettoReferente()!=null){
  603.                     soggettoReferente = new IDSoggetto(filtroRicercaBase.getTipoSoggettoReferente(),filtroRicercaBase.getNomeSoggettoReferente());
  604.                 }
  605.                 idAccordoFiltro = this.idAccordoFactory.getIDAccordoFromValues(filtroRicercaBase.getNomeAccordo(),soggettoReferente,filtroRicercaBase.getVersione());
  606.             }
  607.                         
  608.             String [] urlXMLAccordi = this.uddiLib.getUrlXmlAccordiServizio(idAccordoFiltro,this.urlPrefix);
  609.             
  610.             // Esamina degli accordi
  611.             List<IDAccordo> idAccordi = new ArrayList<IDAccordo>();
  612.             for(int i=0; i<urlXMLAccordi.length; i++){
  613.                 org.openspcoop2.core.registry.AccordoServizioParteComune as = null;
  614.                 
  615.                 /* --- Validazione XSD -- */
  616.                 try{
  617.                     this.validatoreRegistro.valida(urlXMLAccordi[i]);  
  618.                 }catch (Exception e) {
  619.                     throw new DriverRegistroServiziException("["+nomeMetodo+"] Riscontrato errore durante la validazione XSD ("+urlXMLAccordi[i]+"): "+e.getMessage(),e);
  620.                 }
  621.                 
  622.                 // Ottengo oggetto Accordo
  623.                 ByteArrayInputStream bin = null;
  624.                 try{
  625.                     byte[] fileXML = HttpUtilities.requestHTTPFile(urlXMLAccordi[i]);
  626.                     bin = new ByteArrayInputStream(fileXML);
  627.                     org.openspcoop2.core.registry.utils.serializer.JaxbDeserializer deserializer = new org.openspcoop2.core.registry.utils.serializer.JaxbDeserializer();
  628.                     org.openspcoop2.core.registry.RegistroServizi rs = 
  629.                         (org.openspcoop2.core.registry.RegistroServizi) deserializer.readRegistroServizi(bin);
  630.                     if(rs.sizeAccordoServizioParteComuneList()>0)
  631.                         as = rs.getAccordoServizioParteComune(0);
  632.                     bin.close();
  633.                 }catch(Exception e){
  634.                     try{
  635.                         if(bin!=null)
  636.                             bin.close();
  637.                     } catch(Exception eis) {
  638.                         // ignore
  639.                     }
  640.                     throw new DriverRegistroServiziException("["+nomeMetodo+"] Errore durante il parsing xml ("+urlXMLAccordi[i]+"): "+e.getMessage(),e);
  641.                 }
  642.                 if(as==null)
  643.                     throw new DriverRegistroServiziException("["+nomeMetodo+"] accordo non definito per la url ["+urlXMLAccordi[i]+"]");
  644.                 String asURI = this.idAccordoFactory.getUriFromAccordo(as);
  645.                 
  646.                 if(filtroRicercaBase!=null){
  647.                     
  648.                     List<String> tipoSoggettiProtocollo = null;
  649.                     try {
  650.                         if(filtroRicercaBase!=null && (filtroRicercaBase.getProtocollo()!=null || (filtroRicercaBase.getProtocolli()!=null && !filtroRicercaBase.getProtocolli().isEmpty()))){
  651.                             tipoSoggettiProtocollo = Filtri.convertToTipiSoggetti(filtroRicercaBase.getProtocollo(), Filtri.convertToString(filtroRicercaBase.getProtocolli()));
  652.                         }
  653.                     }catch(Exception e) {
  654.                         throw new DriverRegistroServiziException(e.getMessage(),e);
  655.                     }
  656.                     boolean searchByTipoSoggetto = (tipoSoggettiProtocollo!=null && tipoSoggettiProtocollo.size()>0);
  657.                     
  658.                     // Filtro By Data
  659.                     if(filtroRicercaBase.getMinDate()!=null){
  660.                         if(as.getOraRegistrazione()==null){
  661.                             this.log.debug("["+nomeMetodo+"](FiltroByMinDate) Accordo di servizio ["+asURI+"] non valorizzato nell'ora-registrazione. Non inserito nella lista ritornata.");
  662.                             continue;
  663.                         }else if(as.getOraRegistrazione().before(filtroRicercaBase.getMinDate())){
  664.                             continue;
  665.                         }
  666.                     }
  667.                     if(filtroRicercaBase.getMaxDate()!=null){
  668.                         if(as.getOraRegistrazione()==null){
  669.                             this.log.debug("["+nomeMetodo+"](FiltroByMaxDate) Accordo di servizio ["+asURI+"] non valorizzato nell'ora-registrazione. Non inserito nella lista ritornata.");
  670.                             continue;
  671.                         }else if(as.getOraRegistrazione().after(filtroRicercaBase.getMaxDate())){
  672.                             continue;
  673.                         }
  674.                     }
  675.                     // Filtro By Nome
  676.                     if(filtroRicercaBase.getNomeAccordo()!=null){
  677.                         if(as.getNome().equals(filtroRicercaBase.getNomeAccordo()) == false){
  678.                             continue;
  679.                         }
  680.                     }
  681.                     if(filtroRicercaBase.getVersione()!=null){
  682.                         if(as.getVersione().equals(filtroRicercaBase.getVersione()) == false){
  683.                             continue;
  684.                         }
  685.                     }
  686.                     if(searchByTipoSoggetto || filtroRicercaBase.getTipoSoggettoReferente()!=null || filtroRicercaBase.getNomeSoggettoReferente()!=null){
  687.                         if(as.getSoggettoReferente()==null)
  688.                             continue;
  689.                         if(filtroRicercaBase.getTipoSoggettoReferente()!=null){
  690.                             if(as.getSoggettoReferente().getTipo().equals(filtroRicercaBase.getTipoSoggettoReferente()) == false){
  691.                                 continue;
  692.                             }
  693.                         }
  694.                         else if(searchByTipoSoggetto) {
  695.                             boolean find = false;
  696.                             for (String tipoSoggettoProtocollo : tipoSoggettiProtocollo) {
  697.                                 if(as.getSoggettoReferente().getTipo().equals(tipoSoggettoProtocollo)){
  698.                                     find = true;
  699.                                     break;
  700.                                 }
  701.                             }
  702.                             if(!find) {
  703.                                 continue;
  704.                             }
  705.                         }
  706.                         if(filtroRicercaBase.getNomeSoggettoReferente()!=null){
  707.                             if(as.getSoggettoReferente().getNome().equals(filtroRicercaBase.getNomeSoggettoReferente()) == false){
  708.                                 continue;
  709.                             }
  710.                         }
  711.                     }
  712.                     if(filtroRicercaBase.getServiceBinding()!=null){
  713.                         if(as.getServiceBinding().equals(filtroRicercaBase.getServiceBinding()) == false){
  714.                             continue;
  715.                         }
  716.                     }
  717.                     if(filtroRicercaBase.getIdGruppo()!=null && filtroRicercaBase.getIdGruppo().getNome()!=null){
  718.                         boolean found = false;
  719.                         if(as.getGruppi()!=null && as.getGruppi().sizeGruppoList()>0) {
  720.                             for (GruppoAccordo gruppo : as.getGruppi().getGruppoList()) {
  721.                                 if(gruppo.getNome().equals(filtroRicercaBase.getIdGruppo().getNome())) {
  722.                                     found = true;
  723.                                     break;
  724.                                 }
  725.                             }
  726.                         }
  727.                         if(!found) {
  728.                             continue;
  729.                         }
  730.                     }
  731.                     
  732.                     if(filtroRicercaBase.getIdAccordoCooperazione()!=null &&
  733.                             (filtroRicercaBase.getIdAccordoCooperazione().getNome()!=null || 
  734.                             filtroRicercaBase.getIdAccordoCooperazione().getVersione()!=null) ){
  735.                         if(as.getServizioComposto()==null){
  736.                             continue;
  737.                         }
  738.                         IDAccordoCooperazione idAC = this.idAccordoCooperazioneFactory.getIDAccordoFromUri(as.getServizioComposto().getAccordoCooperazione());
  739.                         if(filtroRicercaBase.getIdAccordoCooperazione().getNome()!=null){
  740.                             if(idAC.getNome().equals(filtroRicercaBase.getIdAccordoCooperazione().getNome())== false){
  741.                                 continue;
  742.                             }
  743.                         }
  744.                         if(filtroRicercaBase.getIdAccordoCooperazione().getVersione()!=null){
  745.                             if(idAC.getVersione().equals(filtroRicercaBase.getIdAccordoCooperazione().getVersione())== false){
  746.                                 continue;
  747.                             }
  748.                         }
  749.                     }
  750.                     else if(filtroRicercaBase.isServizioComposto()!=null){
  751.                         if(filtroRicercaBase.isServizioComposto()){
  752.                             if(as.getServizioComposto()==null){
  753.                                 continue;
  754.                             }
  755.                         }
  756.                         else {
  757.                             if(as.getServizioComposto()!=null){
  758.                                 continue;
  759.                             }
  760.                         }
  761.                     }
  762.                     
  763.                     // ProtocolProperties
  764.                     if(ProtocolPropertiesUtilities.isMatch(as, filtroRicercaBase.getProtocolPropertiesAccordo())==false){
  765.                         continue;
  766.                     }
  767.                     
  768.                 }
  769.                 
  770.                 IDAccordo idAccordo = this.idAccordoFactory.getIDAccordoFromValues(as.getNome(),BeanUtilities.getSoggettoReferenteID(as.getSoggettoReferente()),as.getVersione());
  771.                 
  772.                 if(filtroPT!=null){
  773.                     for (PortType pt : as.getPortTypeList()) {
  774.                         // Nome PT
  775.                         if(filtroPT.getNomePortType()!=null){
  776.                             if(pt.getNome().equals(filtroPT.getNomePortType()) == false){
  777.                                 continue;
  778.                             }
  779.                         }
  780.                         // ProtocolProperties PT
  781.                         if(ProtocolPropertiesUtilities.isMatch(pt, filtroPT.getProtocolPropertiesPortType())==false){
  782.                             continue;
  783.                         }
  784.                         
  785.                         IDPortType idPT = new IDPortType();
  786.                         idPT.setIdAccordo(idAccordo);
  787.                         idPT.setNome(pt.getNome());
  788.                         listReturn.add((T)idPT);
  789.                     }
  790.                 }
  791.                 else if(filtroOP!=null){
  792.                     for (PortType pt : as.getPortTypeList()) {
  793.                         
  794.                         // Nome PT
  795.                         if(filtroOP.getNomePortType()!=null){
  796.                             if(pt.getNome().equals(filtroOP.getNomePortType()) == false){
  797.                                 continue;
  798.                             }
  799.                         }
  800.                         // ProtocolProperties PT
  801.                         if(ProtocolPropertiesUtilities.isMatch(pt, filtroOP.getProtocolPropertiesPortType())==false){
  802.                             continue;
  803.                         }
  804.                         
  805.                         for (Operation op : pt.getAzioneList()) {
  806.                             
  807.                             // Nome OP
  808.                             if(filtroOP.getNomeAzione()!=null){
  809.                                 if(op.getNome().equals(filtroOP.getNomeAzione()) == false){
  810.                                     continue;
  811.                                 }
  812.                             }
  813.                             // ProtocolProperties OP
  814.                             if(ProtocolPropertiesUtilities.isMatch(pt, filtroOP.getProtocolPropertiesAzione())==false){
  815.                                 continue;
  816.                             }
  817.                         
  818.                             IDPortTypeAzione idAzione = new IDPortTypeAzione();
  819.                             IDPortType idPT = new IDPortType();
  820.                             idPT.setIdAccordo(idAccordo);
  821.                             idPT.setNome(pt.getNome());
  822.                             idAzione.setIdPortType(idPT);
  823.                             idAzione.setNome(op.getNome());
  824.                             listReturn.add((T)idAzione);
  825.                         }
  826.                     }
  827.                 }
  828.                 else if(filtroAZ!=null){
  829.                     for (Azione az : as.getAzioneList()) {
  830.                         
  831.                         // Nome AZ
  832.                         if(filtroAZ.getNomeAzione()!=null){
  833.                             if(az.getNome().equals(filtroAZ.getNomeAzione()) == false){
  834.                                 continue;
  835.                             }
  836.                         }
  837.                         // ProtocolProperties PT
  838.                         if(ProtocolPropertiesUtilities.isMatch(az, filtroAZ.getProtocolPropertiesAzione())==false){
  839.                             continue;
  840.                         }
  841.                         
  842.                         IDAccordoAzione idAzione = new IDAccordoAzione();
  843.                         idAzione.setIdAccordo(idAccordo);
  844.                         idAzione.setNome(az.getNome());
  845.                         listReturn.add((T)idAzione);
  846.                     }
  847.                 }
  848.                 else if(filtroResource!=null){
  849.                     for (Resource resource : as.getResourceList()) {
  850.                         // Nome Risorsa
  851.                         if(filtroResource.getResourceName()!=null){
  852.                             if(resource.getNome().equals(filtroResource.getResourceName()) == false){
  853.                                 continue;
  854.                             }
  855.                         }
  856.                         // ProtocolProperties PT
  857.                         if(ProtocolPropertiesUtilities.isMatch(resource, filtroResource.getProtocolPropertiesResources())==false){
  858.                             continue;
  859.                         }
  860.                         
  861.                         IDResource idResource = new IDResource();
  862.                         idResource.setIdAccordo(idAccordo);
  863.                         idResource.setNome(resource.getNome());
  864.                         listReturn.add((T)idResource);
  865.                     }
  866.                 }
  867.                 else{
  868.                     listReturn.add((T)idAccordo);
  869.                 }
  870.             }
  871.             if(idAccordi.size()<=0){
  872.                 String msgFiltro = "Elementi non trovati che rispettano il filtro di ricerca selezionato: ";
  873.                 if(filtroPT!=null){
  874.                     throw new DriverRegistroServiziNotFound(msgFiltro+filtroPT.toString());
  875.                 }
  876.                 else if(filtroOP!=null){
  877.                     throw new DriverRegistroServiziNotFound(msgFiltro+filtroOP.toString());
  878.                 }
  879.                 else if(filtroAZ!=null){
  880.                     throw new DriverRegistroServiziNotFound(msgFiltro+filtroAZ.toString());
  881.                 }
  882.                 else if(filtroRicercaBase!=null){
  883.                     throw new DriverRegistroServiziNotFound(msgFiltro+filtroRicercaBase.toString());
  884.                 }
  885.                 else{
  886.                     throw new DriverRegistroServiziNotFound("Elementi non trovati");
  887.                 }
  888.             }
  889.         }catch(Exception e){
  890.             if(e instanceof DriverRegistroServiziNotFound)
  891.                 throw (DriverRegistroServiziNotFound)e;
  892.             else
  893.                 throw new DriverRegistroServiziException(nomeMetodo+" error",e);
  894.         }
  895.     }
  896.     
  897.     @Override
  898.     public Documento getAllegato(IDAccordo idAccordo, String nome) throws DriverRegistroServiziException,DriverRegistroServiziNotFound{
  899.         throw new DriverRegistroServiziException("Not Implemented");
  900.     }
  901.     @Override
  902.     public Documento getSpecificaSemiformale(IDAccordo idAccordo, TipiDocumentoSemiformale tipo, String nome)throws DriverRegistroServiziException,DriverRegistroServiziNotFound{
  903.         throw new DriverRegistroServiziException("Not Implemented");
  904.     }
  905.     
  906.     
  907.     
  908.     
  909.     /* Porte di Dominio */
  910.     
  911.     /**
  912.      * Si occupa di ritornare l'oggetto {@link org.openspcoop2.core.registry.PortaDominio}, 
  913.      * identificato grazie al parametro 
  914.      * <var>nomePdD</var> 
  915.      *
  916.      * @param nomePdD Nome della Porta di Dominio
  917.      * @return un oggetto di tipo {@link org.openspcoop2.core.registry.PortaDominio}.
  918.      * 
  919.      */
  920.     @Override
  921.     public org.openspcoop2.core.registry.PortaDominio getPortaDominio(String nomePdD) throws DriverRegistroServiziException,DriverRegistroServiziNotFound{
  922.         if( nomePdD == null)
  923.             throw new DriverRegistroServiziException("[getPortaDominio] Parametro Non Valido");

  925.         //       controllo inizializzazione UDDI
  926.         if(this.uddiLib.create == false){
  927.             throw new DriverRegistroServiziException("[getPortaDominio] Inizializzazione dell'engine UDDI errata");
  928.         }
  929.         
  930.         //       Controllo pre-esistenza della porta di dominio
  931.         if( this.uddiLib.existsPortaDominio(nomePdD) == false){
  932.             throw new DriverRegistroServiziNotFound("[getPortaDominio] Porta di dominio richiesta non esiste: "+nomePdD);
  933.         } 
  934.         
  935.         org.openspcoop2.core.registry.PortaDominio pddRichiesta = null;

  937.         // Ottengo URL XML associato alla porta di dominio
  938.         String urlXMLPortaDominio = this.uddiLib.getUrlXmlPortaDominio(nomePdD);
  939.         if(urlXMLPortaDominio == null){
  940.             throw new DriverRegistroServiziException("[getPortaDominio] definzione XML non disponibile");
  941.         }

  943.         // Ottengo oggetto PortaDominio
  944.         ByteArrayInputStream bin = null;
  945.         try{
  946.             byte[] fileXML = null;
  947.             try{
  948.                 fileXML = HttpUtilities.requestHTTPFile(urlXMLPortaDominio);
  949.             }catch(UtilsException e){
  950.                 // Controllo pre-esistenza dell'accordo
  951.                 if( "404".equals(e.getMessage()) ){
  952.                     throw new DriverRegistroServiziNotFound("[getPortaDominio] Porta di dominio richiesta non esiste nel repository http: "+nomePdD);
  953.                 } else
  954.                     throw e;
  955.             }
  956.             
  957.             /* --- Validazione XSD (ora che sono sicuro che non ho un 404) -- */
  958.             try{
  959.                 this.validatoreRegistro.valida(urlXMLPortaDominio);  
  960.             }catch (Exception e) {
  961.                 throw new DriverRegistroServiziException("[getPortaDominio] Riscontrato errore durante la validazione XSD della Porta di dominio("+nomePdD+"): "+e.getMessage(),e);
  962.             }
  963.             
  964.             // parsing
  965.             bin = new ByteArrayInputStream(fileXML);
  966.             org.openspcoop2.core.registry.utils.serializer.JaxbDeserializer deserializer = new org.openspcoop2.core.registry.utils.serializer.JaxbDeserializer();
  967.             org.openspcoop2.core.registry.RegistroServizi rs = 
  968.                 (org.openspcoop2.core.registry.RegistroServizi) deserializer.readRegistroServizi(bin);
  969.             if(rs.sizePortaDominioList()>0)
  970.                 pddRichiesta = rs.getPortaDominio(0);
  971.             bin.close();
  972.         }catch(Exception e){
  973.             try{
  974.                 if(bin!=null)
  975.                     bin.close();
  976.             } catch(Exception eis) {
  977.                 // ignore
  978.             }
  979.             if(e instanceof DriverRegistroServiziNotFound)
  980.                 throw (DriverRegistroServiziNotFound)e;
  981.             else
  982.                 throw new DriverRegistroServiziException("[getPortaDominio] Errore durante il parsing xml della Porta di dominio("+nomePdD+"): "+e.getMessage(),e);
  983.         }

  985.         if(pddRichiesta==null)
  986.             throw new DriverRegistroServiziNotFound("[getPortaDominio] Porta di dominio ["+nomePdD+"] non trovata.");
  987.         
  988.         return pddRichiesta;
  989.     }

  991.     /**
  992.      * Ritorna gli identificatori delle PdD che rispettano il parametro di ricerca
  993.      * 
  994.      * @param filtroRicerca
  995.      * @return Una lista di ID degli accordi trovati
  996.      * @throws DriverRegistroServiziException
  997.      * @throws DriverRegistroServiziNotFound
  998.      */
  999.     @Override
  1000.     public List<String> getAllIdPorteDominio(FiltroRicerca filtroRicerca) throws DriverRegistroServiziException,DriverRegistroServiziNotFound{
  1001.         try{

  1003.             // Ricerca UDDI delle porte di dominio
  1004.             /*if(this.urlPrefix==null){
  1005.                 throw new DriverRegistroServiziException("[getAllIdPorteDominio] Implementazione non eseguibile se il driver non viene inizializzato con urlPrefix.");
  1006.             }*/
  1007.             
  1008.             String nomeFiltro = null;
  1009.             if(filtroRicerca!=null)
  1010.                 nomeFiltro = filtroRicerca.getNome();
  1011.             String [] urlXMLPdd = this.uddiLib.getUrlXmlPortaDominio(nomeFiltro,this.urlPrefix);
  1012.             
  1013.             // Esamina delle porte di dominio
  1014.             List<String> nomiPdd = new ArrayList<>();
  1015.             for(int i=0; i<urlXMLPdd.length; i++){
  1016.                 org.openspcoop2.core.registry.PortaDominio pd = null;
  1017.                 
  1018.                 /* --- Validazione XSD -- */
  1019.                 try{
  1020.                     this.validatoreRegistro.valida(urlXMLPdd[i]);  
  1021.                 }catch (Exception e) {
  1022.                     throw new DriverRegistroServiziException("[getAllIdPorteDominio] Riscontrato errore durante la validazione XSD ("+urlXMLPdd[i]+"): "+e.getMessage(),e);
  1023.                 }
  1024.                 
  1025.                 // Ottengo oggetto Porta di dominio
  1026.                 ByteArrayInputStream bin = null;
  1027.                 try{
  1028.                     byte[] fileXML = HttpUtilities.requestHTTPFile(urlXMLPdd[i]);
  1029.                     bin = new ByteArrayInputStream(fileXML);
  1030.                     org.openspcoop2.core.registry.utils.serializer.JaxbDeserializer deserializer = new org.openspcoop2.core.registry.utils.serializer.JaxbDeserializer();
  1031.                     org.openspcoop2.core.registry.RegistroServizi rs = 
  1032.                         (org.openspcoop2.core.registry.RegistroServizi) deserializer.readRegistroServizi(bin);
  1033.                     if(rs.sizePortaDominioList()>0)
  1034.                         pd = rs.getPortaDominio(0);
  1035.                     bin.close();
  1036.                 }catch(Exception e){
  1037.                     try{
  1038.                         if(bin!=null)
  1039.                             bin.close();
  1040.                     } catch(Exception eis) {
  1041.                         // ignore
  1042.                     }
  1043.                     throw new DriverRegistroServiziException("[getAllIdPorteDominio] Errore durante il parsing xml ("+urlXMLPdd[i]+"): "+e.getMessage(),e);
  1044.                 }
  1045.                 if(pd==null)
  1046.                     throw new DriverRegistroServiziException("[getAllIdPorteDominio] porta di dominio non definita per la url ["+urlXMLPdd[i]+"]");
  1047.                 
  1048.                 if(filtroRicerca!=null){
  1049.                     // Filtro By Data
  1050.                     if(filtroRicerca.getMinDate()!=null){
  1051.                         if(pd.getOraRegistrazione()==null){
  1052.                             this.log.debug("[getAllIdPorteDominio](FiltroByMinDate) Porta di dominio ["+pd.getNome()+"] non valorizzata nell'ora-registrazione. Non inserito nella lista ritornata.");
  1053.                             continue;
  1054.                         }else if(pd.getOraRegistrazione().before(filtroRicerca.getMinDate())){
  1055.                             continue;
  1056.                         }
  1057.                     }
  1058.                     if(filtroRicerca.getMaxDate()!=null){
  1059.                         if(pd.getOraRegistrazione()==null){
  1060.                             this.log.debug("[getAllIdPorteDominio](FiltroByMaxDate) Porta di dominio ["+pd.getNome()+"] non valorizzata nell'ora-registrazione. Non inserito nella lista ritornata.");
  1061.                             continue;
  1062.                         }else if(pd.getOraRegistrazione().after(filtroRicerca.getMaxDate())){
  1063.                             continue;
  1064.                         }
  1065.                     }
  1066.                     // Filtro By Nome
  1067.                     if(filtroRicerca.getNome()!=null){
  1068.                         if(pd.getNome().equals(filtroRicerca.getNome()) == false){
  1069.                             continue;
  1070.                         }
  1071.                     }
  1072.                 }
  1073.                 nomiPdd.add(pd.getNome());
  1074.             }
  1075.             if(nomiPdd.size()==0){
  1076.                 throw new DriverRegistroServiziNotFound("Porte di dominio non trovate che rispettano il filtro di ricerca selezionato: "+filtroRicerca.toString());
  1077.             }else{
  1078.                 return nomiPdd;
  1079.             }
  1080.         }catch(Exception e){
  1081.             if(e instanceof DriverRegistroServiziNotFound)
  1082.                 throw (DriverRegistroServiziNotFound)e;
  1083.             else
  1084.                 throw new DriverRegistroServiziException("getAllIdPorteDominio error",e);
  1085.         }
  1086.     }
  1087.     
  1088.     
  1089.     
  1090.     
  1091.     /* Gruppi */
  1092.     
  1093.     /**
  1094.      * Si occupa di ritornare l'oggetto {@link org.openspcoop2.core.registry.Gruppo}, 
  1095.      * identificato grazie al parametro 
  1096.      * <var>nome</var> 
  1097.      *
  1098.      * @param idGruppo Identificativo del gruppo
  1099.      * @return un oggetto di tipo {@link org.openspcoop2.core.registry.Gruppo}.
  1100.      * 
  1101.      */
  1102.     @Override
  1103.     public Gruppo getGruppo(
  1104.             IDGruppo idGruppo) throws DriverRegistroServiziException, DriverRegistroServiziNotFound{
  1105.         if(idGruppo==null || idGruppo.getNome()==null)
  1106.             throw new DriverRegistroServiziException("[getGruppo] Parametro Non Valido");

  1108.         //       controllo inizializzazione UDDI
  1109.         if(this.uddiLib.create == false){
  1110.             throw new DriverRegistroServiziException("[getGruppo] Inizializzazione dell'engine UDDI errata");
  1111.         }
  1112.         
  1113.         //       Controllo pre-esistenza del gruppo
  1114.         if( this.uddiLib.existsGruppo(idGruppo.getNome()) == false){
  1115.             throw new DriverRegistroServiziNotFound("[getGruppo] Gruppo richiesto non esiste: "+idGruppo.getNome());
  1116.         } 
  1117.         
  1118.         org.openspcoop2.core.registry.Gruppo gruppoRichiesto = null;

  1120.         // Ottengo URL XML associato al gruppo
  1121.         String urlXMLGruppo = this.uddiLib.getUrlXmlGruppo(idGruppo.getNome());
  1122.         if(urlXMLGruppo == null){
  1123.             throw new DriverRegistroServiziException("[getGruppo] definzione XML non disponibile");
  1124.         }

  1126.         // Ottengo oggetto PortaDominio
  1127.         ByteArrayInputStream bin = null;
  1128.         try{
  1129.             byte[] fileXML = null;
  1130.             try{
  1131.                 fileXML = HttpUtilities.requestHTTPFile(urlXMLGruppo);
  1132.             }catch(UtilsException e){
  1133.                 // Controllo pre-esistenza dell'accordo
  1134.                 if( "404".equals(e.getMessage()) ){
  1135.                     throw new DriverRegistroServiziNotFound("[getGruppo] Gruppo richiesto non esiste nel repository http: "+idGruppo.getNome());
  1136.                 } else
  1137.                     throw e;
  1138.             }
  1139.             
  1140.             /* --- Validazione XSD (ora che sono sicuro che non ho un 404) -- */
  1141.             try{
  1142.                 this.validatoreRegistro.valida(urlXMLGruppo);  
  1143.             }catch (Exception e) {
  1144.                 throw new DriverRegistroServiziException("[getGruppo] Riscontrato errore durante la validazione XSD del Gruppo ("+idGruppo.getNome()+"): "+e.getMessage(),e);
  1145.             }
  1146.             
  1147.             // parsing
  1148.             bin = new ByteArrayInputStream(fileXML);
  1149.             org.openspcoop2.core.registry.utils.serializer.JaxbDeserializer deserializer = new org.openspcoop2.core.registry.utils.serializer.JaxbDeserializer();
  1150.             org.openspcoop2.core.registry.RegistroServizi rs = 
  1151.                 (org.openspcoop2.core.registry.RegistroServizi) deserializer.readRegistroServizi(bin);
  1152.             if(rs.sizeGruppoList()>0)
  1153.                 gruppoRichiesto = rs.getGruppo(0);
  1154.             bin.close();
  1155.         }catch(Exception e){
  1156.             try{
  1157.                 if(bin!=null)
  1158.                     bin.close();
  1159.             } catch(Exception eis) {
  1160.                 // ignore
  1161.             }
  1162.             if(e instanceof DriverRegistroServiziNotFound)
  1163.                 throw (DriverRegistroServiziNotFound)e;
  1164.             else
  1165.                 throw new DriverRegistroServiziException("[getGruppo] Errore durante il parsing xml del Gruppo ("+idGruppo.getNome()+"): "+e.getMessage(),e);
  1166.         }

  1168.         if(gruppoRichiesto==null)
  1169.             throw new DriverRegistroServiziNotFound("[getGruppo] Gruppo ["+idGruppo.getNome()+"] non trovato.");
  1170.         
  1171.         return gruppoRichiesto;
  1172.     }

  1174.     /**
  1175.      * Ritorna gli identificatori dei Gruppi che rispettano il parametro di ricerca
  1176.      * 
  1177.      * @param filtroRicerca
  1178.      * @return Una lista di ID dei gruppi trovati
  1179.      * @throws DriverRegistroServiziException
  1180.      * @throws DriverRegistroServiziNotFound
  1181.      */
  1182.     @Override
  1183.     public List<IDGruppo> getAllIdGruppi(
  1184.             FiltroRicercaGruppi filtroRicerca) throws DriverRegistroServiziException, DriverRegistroServiziNotFound{
  1185.         try{

  1187.             // Ricerca UDDI delle porte di dominio
  1188.             /*if(this.urlPrefix==null){
  1189.                 throw new DriverRegistroServiziException("[getAllIdPorteDominio] Implementazione non eseguibile se il driver non viene inizializzato con urlPrefix.");
  1190.             }*/
  1191.             
  1192.             String nomeFiltro = null;
  1193.             if(filtroRicerca!=null)
  1194.                 nomeFiltro = filtroRicerca.getNome();
  1195.             String [] urlXMLGruppi = this.uddiLib.getUrlXmlGruppo(nomeFiltro,this.urlPrefix);
  1196.             
  1197.             // Esamina dei Gruppi
  1198.             List<IDGruppo> idGruppi = new ArrayList<IDGruppo>();
  1199.             for(int i=0; i<urlXMLGruppi.length; i++){
  1200.                 org.openspcoop2.core.registry.Gruppo gruppo = null;
  1201.                 
  1202.                 /* --- Validazione XSD -- */
  1203.                 try{
  1204.                     this.validatoreRegistro.valida(urlXMLGruppi[i]);  
  1205.                 }catch (Exception e) {
  1206.                     throw new DriverRegistroServiziException("[getAllIdGruppi] Riscontrato errore durante la validazione XSD ("+urlXMLGruppi[i]+"): "+e.getMessage(),e);
  1207.                 }
  1208.                 
  1209.                 // Ottengo oggetto Porta di dominio
  1210.                 ByteArrayInputStream bin = null;
  1211.                 try{
  1212.                     byte[] fileXML = HttpUtilities.requestHTTPFile(urlXMLGruppi[i]);
  1213.                     bin = new ByteArrayInputStream(fileXML);
  1214.                     org.openspcoop2.core.registry.utils.serializer.JaxbDeserializer deserializer = new org.openspcoop2.core.registry.utils.serializer.JaxbDeserializer();
  1215.                     org.openspcoop2.core.registry.RegistroServizi rs = 
  1216.                         (org.openspcoop2.core.registry.RegistroServizi) deserializer.readRegistroServizi(bin);
  1217.                     if(rs.sizeGruppoList()>0)
  1218.                         gruppo = rs.getGruppo(0);
  1219.                     bin.close();
  1220.                 }catch(Exception e){
  1221.                     try{
  1222.                         if(bin!=null)
  1223.                             bin.close();
  1224.                     } catch(Exception eis) {
  1225.                         // ignore
  1226.                     }
  1227.                     throw new DriverRegistroServiziException("[getAllIdGruppi] Errore durante il parsing xml ("+urlXMLGruppi[i]+"): "+e.getMessage(),e);
  1228.                 }
  1229.                 if(gruppo==null)
  1230.                     throw new DriverRegistroServiziException("[getAllIdGruppi] Gruppo non definito per la url ["+urlXMLGruppi[i]+"]");
  1231.                 
  1232.                 if(filtroRicerca!=null){
  1233.                     // Filtro By Data
  1234.                     if(filtroRicerca.getMinDate()!=null){
  1235.                         if(gruppo.getOraRegistrazione()==null){
  1236.                             this.log.debug("[getAllIdGruppi](FiltroByMinDate) Gruppo ["+gruppo.getNome()+"] non valorizzato nell'ora-registrazione. Non inserito nella lista ritornata.");
  1237.                             continue;
  1238.                         }else if(gruppo.getOraRegistrazione().before(filtroRicerca.getMinDate())){
  1239.                             continue;
  1240.                         }
  1241.                     }
  1242.                     if(filtroRicerca.getMaxDate()!=null){
  1243.                         if(gruppo.getOraRegistrazione()==null){
  1244.                             this.log.debug("[getAllIdGruppi](FiltroByMaxDate) Gruppo ["+gruppo.getNome()+"] non valorizzato nell'ora-registrazione. Non inserito nella lista ritornata.");
  1245.                             continue;
  1246.                         }else if(gruppo.getOraRegistrazione().after(filtroRicerca.getMaxDate())){
  1247.                             continue;
  1248.                         }
  1249.                     }
  1250.                     // Filtro By Nome
  1251.                     if(filtroRicerca.getNome()!=null){
  1252.                         if(gruppo.getNome().equals(filtroRicerca.getNome()) == false){
  1253.                             continue;
  1254.                         }
  1255.                     }
  1256.                     // Filtro By ServiceBinding
  1257.                     if(filtroRicerca.getServiceBinding()!=null){
  1258.                         if(gruppo.getServiceBinding()!=null){ // se e' uguale a null significa che va bene per qualsiasi service binding
  1259.                             if(gruppo.getServiceBinding().equals(filtroRicerca.getServiceBinding()) == false) {
  1260.                                 continue;
  1261.                             }
  1262.                         }
  1263.                     }
  1264.                 }
  1265.                 IDGruppo id = new IDGruppo(gruppo.getNome());
  1266.                 idGruppi.add(id);
  1267.             }
  1268.             if(idGruppi.size()==0){
  1269.                 throw new DriverRegistroServiziNotFound("Gruppi non trovati che rispettano il filtro di ricerca selezionato: "+filtroRicerca.toString());
  1270.             }else{
  1271.                 return idGruppi;
  1272.             }
  1273.         }catch(Exception e){
  1274.             if(e instanceof DriverRegistroServiziNotFound)
  1275.                 throw (DriverRegistroServiziNotFound)e;
  1276.             else
  1277.                 throw new DriverRegistroServiziException("getAllIdGruppi error",e);
  1278.         }
  1279.     }
  1280.     
  1281.     
  1282.     
  1283.     
  1284.     
  1285.     
  1286.     /* Ruoli */
  1287.     
  1288.     /**
  1289.      * Si occupa di ritornare l'oggetto {@link org.openspcoop2.core.registry.Ruolo}, 
  1290.      * identificato grazie al parametro 
  1291.      * <var>nome</var> 
  1292.      *
  1293.      * @param idRuolo Identificativo del ruolo
  1294.      * @return un oggetto di tipo {@link org.openspcoop2.core.registry.Ruolo}.
  1295.      * 
  1296.      */
  1297.     @Override
  1298.     public Ruolo getRuolo(
  1299.             IDRuolo idRuolo) throws DriverRegistroServiziException, DriverRegistroServiziNotFound{
  1300.         if(idRuolo==null || idRuolo.getNome()==null)
  1301.             throw new DriverRegistroServiziException("[getRuolo] Parametro Non Valido");

  1303.         //       controllo inizializzazione UDDI
  1304.         if(this.uddiLib.create == false){
  1305.             throw new DriverRegistroServiziException("[getRuolo] Inizializzazione dell'engine UDDI errata");
  1306.         }
  1307.         
  1308.         //       Controllo pre-esistenza del ruolo
  1309.         if( this.uddiLib.existsRuolo(idRuolo.getNome()) == false){
  1310.             throw new DriverRegistroServiziNotFound("[getRuolo] Ruolo richiesto non esiste: "+idRuolo.getNome());
  1311.         } 
  1312.         
  1313.         org.openspcoop2.core.registry.Ruolo ruoloRichiesto = null;

  1315.         // Ottengo URL XML associato al ruolo
  1316.         String urlXMLRuolo = this.uddiLib.getUrlXmlRuolo(idRuolo.getNome());
  1317.         if(urlXMLRuolo == null){
  1318.             throw new DriverRegistroServiziException("[getRuolo] definzione XML non disponibile");
  1319.         }

  1321.         // Ottengo oggetto PortaDominio
  1322.         ByteArrayInputStream bin = null;
  1323.         try{
  1324.             byte[] fileXML = null;
  1325.             try{
  1326.                 fileXML = HttpUtilities.requestHTTPFile(urlXMLRuolo);
  1327.             }catch(UtilsException e){
  1328.                 // Controllo pre-esistenza dell'accordo
  1329.                 if( "404".equals(e.getMessage()) ){
  1330.                     throw new DriverRegistroServiziNotFound("[getRuolo] Ruolo richiesto non esiste nel repository http: "+idRuolo.getNome());
  1331.                 } else
  1332.                     throw e;
  1333.             }
  1334.             
  1335.             /* --- Validazione XSD (ora che sono sicuro che non ho un 404) -- */
  1336.             try{
  1337.                 this.validatoreRegistro.valida(urlXMLRuolo);  
  1338.             }catch (Exception e) {
  1339.                 throw new DriverRegistroServiziException("[getRuolo] Riscontrato errore durante la validazione XSD del Ruolo ("+idRuolo.getNome()+"): "+e.getMessage(),e);
  1340.             }
  1341.             
  1342.             // parsing
  1343.             bin = new ByteArrayInputStream(fileXML);
  1344.             org.openspcoop2.core.registry.utils.serializer.JaxbDeserializer deserializer = new org.openspcoop2.core.registry.utils.serializer.JaxbDeserializer();
  1345.             org.openspcoop2.core.registry.RegistroServizi rs = 
  1346.                 (org.openspcoop2.core.registry.RegistroServizi) deserializer.readRegistroServizi(bin);
  1347.             if(rs.sizeRuoloList()>0)
  1348.                 ruoloRichiesto = rs.getRuolo(0);
  1349.             bin.close();
  1350.         }catch(Exception e){
  1351.             try{
  1352.                 if(bin!=null)
  1353.                     bin.close();
  1354.             } catch(Exception eis) {
  1355.                 // ignore
  1356.             }
  1357.             if(e instanceof DriverRegistroServiziNotFound)
  1358.                 throw (DriverRegistroServiziNotFound)e;
  1359.             else
  1360.                 throw new DriverRegistroServiziException("[getRuolo] Errore durante il parsing xml del Ruolo ("+idRuolo.getNome()+"): "+e.getMessage(),e);
  1361.         }

  1363.         if(ruoloRichiesto==null)
  1364.             throw new DriverRegistroServiziNotFound("[getRuolo] Ruolo ["+idRuolo.getNome()+"] non trovato.");
  1365.         
  1366.         return ruoloRichiesto;
  1367.     }

  1369.     /**
  1370.      * Ritorna gli identificatori dei Ruoli che rispettano il parametro di ricerca
  1371.      * 
  1372.      * @param filtroRicerca
  1373.      * @return Una lista di ID dei ruoli trovati
  1374.      * @throws DriverRegistroServiziException
  1375.      * @throws DriverRegistroServiziNotFound
  1376.      */
  1377.     @Override
  1378.     public List<IDRuolo> getAllIdRuoli(
  1379.             FiltroRicercaRuoli filtroRicerca) throws DriverRegistroServiziException, DriverRegistroServiziNotFound{
  1380.         try{

  1382.             // Ricerca UDDI delle porte di dominio
  1383.             /*if(this.urlPrefix==null){
  1384.                 throw new DriverRegistroServiziException("[getAllIdPorteDominio] Implementazione non eseguibile se il driver non viene inizializzato con urlPrefix.");
  1385.             }*/
  1386.             
  1387.             String nomeFiltro = null;
  1388.             if(filtroRicerca!=null)
  1389.                 nomeFiltro = filtroRicerca.getNome();
  1390.             String [] urlXMLRuoli = this.uddiLib.getUrlXmlRuolo(nomeFiltro,this.urlPrefix);
  1391.             
  1392.             // Esamina dei Ruoli
  1393.             List<IDRuolo> idRuoli = new ArrayList<IDRuolo>();
  1394.             for(int i=0; i<urlXMLRuoli.length; i++){
  1395.                 org.openspcoop2.core.registry.Ruolo ruolo = null;
  1396.                 
  1397.                 /* --- Validazione XSD -- */
  1398.                 try{
  1399.                     this.validatoreRegistro.valida(urlXMLRuoli[i]);  
  1400.                 }catch (Exception e) {
  1401.                     throw new DriverRegistroServiziException("[getAllIdRuoli] Riscontrato errore durante la validazione XSD ("+urlXMLRuoli[i]+"): "+e.getMessage(),e);
  1402.                 }
  1403.                 
  1404.                 // Ottengo oggetto Porta di dominio
  1405.                 ByteArrayInputStream bin = null;
  1406.                 try{
  1407.                     byte[] fileXML = HttpUtilities.requestHTTPFile(urlXMLRuoli[i]);
  1408.                     bin = new ByteArrayInputStream(fileXML);
  1409.                     org.openspcoop2.core.registry.utils.serializer.JaxbDeserializer deserializer = new org.openspcoop2.core.registry.utils.serializer.JaxbDeserializer();
  1410.                     org.openspcoop2.core.registry.RegistroServizi rs = 
  1411.                         (org.openspcoop2.core.registry.RegistroServizi) deserializer.readRegistroServizi(bin);
  1412.                     if(rs.sizeRuoloList()>0)
  1413.                         ruolo = rs.getRuolo(0);
  1414.                     bin.close();
  1415.                 }catch(Exception e){
  1416.                     try{
  1417.                         if(bin!=null)
  1418.                             bin.close();
  1419.                     } catch(Exception eis) {
  1420.                         // ignore
  1421.                     }
  1422.                     throw new DriverRegistroServiziException("[getAllIdRuoli] Errore durante il parsing xml ("+urlXMLRuoli[i]+"): "+e.getMessage(),e);
  1423.                 }
  1424.                 if(ruolo==null)
  1425.                     throw new DriverRegistroServiziException("[getAllIdRuoli] Ruolo non definito per la url ["+urlXMLRuoli[i]+"]");
  1426.                 
  1427.                 if(filtroRicerca!=null){
  1428.                     // Filtro By Data
  1429.                     if(filtroRicerca.getMinDate()!=null){
  1430.                         if(ruolo.getOraRegistrazione()==null){
  1431.                             this.log.debug("[getAllIdRuoli](FiltroByMinDate) Ruolo ["+ruolo.getNome()+"] non valorizzato nell'ora-registrazione. Non inserito nella lista ritornata.");
  1432.                             continue;
  1433.                         }else if(ruolo.getOraRegistrazione().before(filtroRicerca.getMinDate())){
  1434.                             continue;
  1435.                         }
  1436.                     }
  1437.                     if(filtroRicerca.getMaxDate()!=null){
  1438.                         if(ruolo.getOraRegistrazione()==null){
  1439.                             this.log.debug("[getAllIdRuoli](FiltroByMaxDate) Ruolo ["+ruolo.getNome()+"] non valorizzato nell'ora-registrazione. Non inserito nella lista ritornata.");
  1440.                             continue;
  1441.                         }else if(ruolo.getOraRegistrazione().after(filtroRicerca.getMaxDate())){
  1442.                             continue;
  1443.                         }
  1444.                     }
  1445.                     // Filtro By Nome
  1446.                     if(filtroRicerca.getNome()!=null){
  1447.                         if(ruolo.getNome().equals(filtroRicerca.getNome()) == false){
  1448.                             continue;
  1449.                         }
  1450.                     }
  1451.                     // Filtro By Tipologia
  1452.                     if(filtroRicerca.getTipologia()!=null && !RuoloTipologia.QUALSIASI.equals(filtroRicerca.getTipologia())){
  1453.                         if(ruolo.getTipologia()==null){
  1454.                             continue;
  1455.                         }
  1456.                         if(!RuoloTipologia.QUALSIASI.equals(ruolo.getTipologia())){
  1457.                             if(ruolo.getTipologia().equals(filtroRicerca.getTipologia()) == false){
  1458.                                 continue;
  1459.                             }
  1460.                         }
  1461.                     }
  1462.                     // Filtro By Contesto
  1463.                     if(filtroRicerca.getContesto()!=null && !RuoloContesto.QUALSIASI.equals(filtroRicerca.getContesto())){
  1464.                         if(ruolo.getContestoUtilizzo()==null){
  1465.                             continue;
  1466.                         }
  1467.                         if(!RuoloContesto.QUALSIASI.equals(ruolo.getContestoUtilizzo())){
  1468.                             if(ruolo.getContestoUtilizzo().equals(filtroRicerca.getContesto()) == false){
  1469.                                 continue;
  1470.                             }
  1471.                         }
  1472.                     }
  1473.                 }
  1474.                 IDRuolo id = new IDRuolo(ruolo.getNome());
  1475.                 idRuoli.add(id);
  1476.             }
  1477.             if(idRuoli.size()==0){
  1478.                 throw new DriverRegistroServiziNotFound("Ruoli non trovati che rispettano il filtro di ricerca selezionato: "+filtroRicerca.toString());
  1479.             }else{
  1480.                 return idRuoli;
  1481.             }
  1482.         }catch(Exception e){
  1483.             if(e instanceof DriverRegistroServiziNotFound)
  1484.                 throw (DriverRegistroServiziNotFound)e;
  1485.             else
  1486.                 throw new DriverRegistroServiziException("getAllIdRuoli error",e);
  1487.         }
  1488.     }
  1489.     
  1490.     
  1491.     
  1492.     
  1493.     
  1494.     
  1495.     /* Scope */
  1496.     
  1497.     /**
  1498.      * Si occupa di ritornare l'oggetto {@link org.openspcoop2.core.registry.Scope}, 
  1499.      * identificato grazie al parametro 
  1500.      * <var>nome</var> 
  1501.      *
  1502.      * @param idScope Identificativo del scope
  1503.      * @return un oggetto di tipo {@link org.openspcoop2.core.registry.Scope}.
  1504.      * 
  1505.      */
  1506.     @Override
  1507.     public Scope getScope(
  1508.             IDScope idScope) throws DriverRegistroServiziException, DriverRegistroServiziNotFound{
  1509.         if(idScope==null || idScope.getNome()==null)
  1510.             throw new DriverRegistroServiziException("[getScope] Parametro Non Valido");

  1512.         //       controllo inizializzazione UDDI
  1513.         if(this.uddiLib.create == false){
  1514.             throw new DriverRegistroServiziException("[getScope] Inizializzazione dell'engine UDDI errata");
  1515.         }
  1516.         
  1517.         //       Controllo pre-esistenza del scope
  1518.         if( this.uddiLib.existsScope(idScope.getNome()) == false){
  1519.             throw new DriverRegistroServiziNotFound("[getScope] Scope richiesto non esiste: "+idScope.getNome());
  1520.         } 
  1521.         
  1522.         org.openspcoop2.core.registry.Scope scopeRichiesto = null;

  1524.         // Ottengo URL XML associato al scope
  1525.         String urlXMLScope = this.uddiLib.getUrlXmlScope(idScope.getNome());
  1526.         if(urlXMLScope == null){
  1527.             throw new DriverRegistroServiziException("[getScope] definzione XML non disponibile");
  1528.         }

  1530.         // Ottengo oggetto PortaDominio
  1531.         ByteArrayInputStream bin = null;
  1532.         try{
  1533.             byte[] fileXML = null;
  1534.             try{
  1535.                 fileXML = HttpUtilities.requestHTTPFile(urlXMLScope);
  1536.             }catch(UtilsException e){
  1537.                 // Controllo pre-esistenza dell'accordo
  1538.                 if( "404".equals(e.getMessage()) ){
  1539.                     throw new DriverRegistroServiziNotFound("[getScope] Scope richiesto non esiste nel repository http: "+idScope.getNome());
  1540.                 } else
  1541.                     throw e;
  1542.             }
  1543.             
  1544.             /* --- Validazione XSD (ora che sono sicuro che non ho un 404) -- */
  1545.             try{
  1546.                 this.validatoreRegistro.valida(urlXMLScope);  
  1547.             }catch (Exception e) {
  1548.                 throw new DriverRegistroServiziException("[getScope] Riscontrato errore durante la validazione XSD del Scope ("+idScope.getNome()+"): "+e.getMessage(),e);
  1549.             }
  1550.             
  1551.             // parsing
  1552.             bin = new ByteArrayInputStream(fileXML);
  1553.             org.openspcoop2.core.registry.utils.serializer.JaxbDeserializer deserializer = new org.openspcoop2.core.registry.utils.serializer.JaxbDeserializer();
  1554.             org.openspcoop2.core.registry.RegistroServizi rs = 
  1555.                 (org.openspcoop2.core.registry.RegistroServizi) deserializer.readRegistroServizi(bin);
  1556.             if(rs.sizeScopeList()>0)
  1557.                 scopeRichiesto = rs.getScope(0);
  1558.             bin.close();
  1559.         }catch(Exception e){
  1560.             try{
  1561.                 if(bin!=null)
  1562.                     bin.close();
  1563.             } catch(Exception eis) {
  1564.                 // ignore
  1565.             }
  1566.             if(e instanceof DriverRegistroServiziNotFound)
  1567.                 throw (DriverRegistroServiziNotFound)e;
  1568.             else
  1569.                 throw new DriverRegistroServiziException("[getScope] Errore durante il parsing xml del Scope ("+idScope.getNome()+"): "+e.getMessage(),e);
  1570.         }

  1572.         if(scopeRichiesto==null)
  1573.             throw new DriverRegistroServiziNotFound("[getScope] Scope ["+idScope.getNome()+"] non trovato.");
  1574.         
  1575.         return scopeRichiesto;
  1576.     }

  1578.     /**
  1579.      * Ritorna gli identificatori dei Scope che rispettano il parametro di ricerca
  1580.      * 
  1581.      * @param filtroRicerca
  1582.      * @return Una lista di ID dei scope trovati
  1583.      * @throws DriverRegistroServiziException
  1584.      * @throws DriverRegistroServiziNotFound
  1585.      */
  1586.     @Override
  1587.     public List<IDScope> getAllIdScope(
  1588.             FiltroRicercaScope filtroRicerca) throws DriverRegistroServiziException, DriverRegistroServiziNotFound{
  1589.         try{

  1591.             // Ricerca UDDI delle porte di dominio
  1592.             /*if(this.urlPrefix==null){
  1593.                 throw new DriverRegistroServiziException("[getAllIdPorteDominio] Implementazione non eseguibile se il driver non viene inizializzato con urlPrefix.");
  1594.             }*/
  1595.             
  1596.             String nomeFiltro = null;
  1597.             if(filtroRicerca!=null)
  1598.                 nomeFiltro = filtroRicerca.getNome();
  1599.             String [] urlXMLScope = this.uddiLib.getUrlXmlScope(nomeFiltro,this.urlPrefix);
  1600.             
  1601.             // Esamina dei Scope
  1602.             List<IDScope> idScope = new ArrayList<IDScope>();
  1603.             for(int i=0; i<urlXMLScope.length; i++){
  1604.                 org.openspcoop2.core.registry.Scope scope = null;
  1605.                 
  1606.                 /* --- Validazione XSD -- */
  1607.                 try{
  1608.                     this.validatoreRegistro.valida(urlXMLScope[i]);  
  1609.                 }catch (Exception e) {
  1610.                     throw new DriverRegistroServiziException("[getAllIdScope] Riscontrato errore durante la validazione XSD ("+urlXMLScope[i]+"): "+e.getMessage(),e);
  1611.                 }
  1612.                 
  1613.                 // Ottengo oggetto Porta di dominio
  1614.                 ByteArrayInputStream bin = null;
  1615.                 try{
  1616.                     byte[] fileXML = HttpUtilities.requestHTTPFile(urlXMLScope[i]);
  1617.                     bin = new ByteArrayInputStream(fileXML);
  1618.                     org.openspcoop2.core.registry.utils.serializer.JaxbDeserializer deserializer = new org.openspcoop2.core.registry.utils.serializer.JaxbDeserializer();
  1619.                     org.openspcoop2.core.registry.RegistroServizi rs = 
  1620.                         (org.openspcoop2.core.registry.RegistroServizi) deserializer.readRegistroServizi(bin);
  1621.                     if(rs.sizeScopeList()>0)
  1622.                         scope = rs.getScope(0);
  1623.                     bin.close();
  1624.                 }catch(Exception e){
  1625.                     try{
  1626.                         if(bin!=null)
  1627.                             bin.close();
  1628.                     } catch(Exception eis) {
  1629.                         // ignore
  1630.                     }
  1631.                     throw new DriverRegistroServiziException("[getAllIdScope] Errore durante il parsing xml ("+urlXMLScope[i]+"): "+e.getMessage(),e);
  1632.                 }
  1633.                 if(scope==null)
  1634.                     throw new DriverRegistroServiziException("[getAllIdScope] Scope non definito per la url ["+urlXMLScope[i]+"]");
  1635.                 
  1636.                 if(filtroRicerca!=null){
  1637.                     // Filtro By Data
  1638.                     if(filtroRicerca.getMinDate()!=null){
  1639.                         if(scope.getOraRegistrazione()==null){
  1640.                             this.log.debug("[getAllIdScope](FiltroByMinDate) Scope ["+scope.getNome()+"] non valorizzato nell'ora-registrazione. Non inserito nella lista ritornata.");
  1641.                             continue;
  1642.                         }else if(scope.getOraRegistrazione().before(filtroRicerca.getMinDate())){
  1643.                             continue;
  1644.                         }
  1645.                     }
  1646.                     if(filtroRicerca.getMaxDate()!=null){
  1647.                         if(scope.getOraRegistrazione()==null){
  1648.                             this.log.debug("[getAllIdScope](FiltroByMaxDate) Scope ["+scope.getNome()+"] non valorizzato nell'ora-registrazione. Non inserito nella lista ritornata.");
  1649.                             continue;
  1650.                         }else if(scope.getOraRegistrazione().after(filtroRicerca.getMaxDate())){
  1651.                             continue;
  1652.                         }
  1653.                     }
  1654.                     // Filtro By Nome
  1655.                     if(filtroRicerca.getNome()!=null){
  1656.                         if(scope.getNome().equals(filtroRicerca.getNome()) == false){
  1657.                             continue;
  1658.                         }
  1659.                     }
  1660.                     // Filtro By Tipologia
  1661.                     if(filtroRicerca.getTipologia()!=null){
  1662.                         if(scope.getTipologia()==null){
  1663.                             continue;
  1664.                         }
  1665.                         if(scope.getTipologia().equals(filtroRicerca.getTipologia()) == false){
  1666.                             continue;
  1667.                         }
  1668.                     }
  1669.                     // Filtro By Contesto
  1670.                     if(filtroRicerca.getContesto()!=null && !ScopeContesto.QUALSIASI.equals(filtroRicerca.getContesto())){
  1671.                         if(scope.getContestoUtilizzo()==null){
  1672.                             continue;
  1673.                         }
  1674.                         if(!ScopeContesto.QUALSIASI.equals(scope.getContestoUtilizzo())){
  1675.                             if(scope.getContestoUtilizzo().equals(filtroRicerca.getContesto()) == false){
  1676.                                 continue;
  1677.                             }
  1678.                         }
  1679.                     }
  1680.                 }
  1681.                 IDScope id = new IDScope(scope.getNome());
  1682.                 idScope.add(id);
  1683.             }
  1684.             if(idScope.size()==0){
  1685.                 throw new DriverRegistroServiziNotFound("Scope non trovati che rispettano il filtro di ricerca selezionato: "+filtroRicerca.toString());
  1686.             }else{
  1687.                 return idScope;
  1688.             }
  1689.         }catch(Exception e){
  1690.             if(e instanceof DriverRegistroServiziNotFound)
  1691.                 throw (DriverRegistroServiziNotFound)e;
  1692.             else
  1693.                 throw new DriverRegistroServiziException("getAllIdScope error",e);
  1694.         }
  1695.     }
  1696.     
  1697.     
  1698.     
  1699.     
  1700.     
  1701.     
  1702.     /* Soggetti */
  1703.     
  1704.     /**
  1705.      * Si occupa di ritornare l'oggetto {@link org.openspcoop2.core.registry.Soggetto}, 
  1706.      * identificato grazie al parametro 
  1707.      * <var>idSoggetto</var> di tipo {@link org.openspcoop2.core.id.IDSoggetto}. 
  1708.      *
  1709.      * @param idSoggetto Identificatore del Soggetto di tipo {@link org.openspcoop2.core.id.IDSoggetto}.
  1710.      * @return l'oggetto di tipo {@link org.openspcoop2.core.registry.Soggetto} 
  1711.      * 
  1712.      */
  1713.     @Override
  1714.     public org.openspcoop2.core.registry.Soggetto getSoggetto(IDSoggetto idSoggetto) throws DriverRegistroServiziException,DriverRegistroServiziNotFound{

  1716.         if(idSoggetto==null)
  1717.             throw new DriverRegistroServiziException("[getSoggetto] Parametro Non Valido");
  1718.         
  1719.         //       controllo inizializzazione UDDI
  1720.         if(this.uddiLib.create == false){
  1721.             throw new DriverRegistroServiziException("[getSoggetto] Inizializzazione dell'engine UDDI errata");
  1722.         }
  1723.         
  1724.         
  1725.         if( this.uddiLib.existsSoggetto(idSoggetto) == false){
  1726.             throw new DriverRegistroServiziNotFound("[getSoggetto] Il soggetto ["+idSoggetto.getTipo()+"/"+idSoggetto.getNome()+
  1727.             "] non risulta gia' inserito nel registro dei servizi.");
  1728.         } 
  1729.         
  1730.         org.openspcoop2.core.registry.Soggetto soggRichiesto = null;

  1732.         // Ottengo URL XML associato al Soggetto
  1733.         String urlXMLSoggetto = this.uddiLib.getUrlXmlSoggetto(idSoggetto);
  1734.         if(urlXMLSoggetto == null){
  1735.             throw new DriverRegistroServiziException("[getSoggetto] Definizione xml non disponibile");
  1736.         }

  1738.         // Ottengo oggetto Soggetto
  1739.         ByteArrayInputStream bin = null;
  1740.         try{
  1741.             byte[] fileXML = null;
  1742.             try{
  1743.                 fileXML = HttpUtilities.requestHTTPFile(urlXMLSoggetto);
  1744.             }catch(UtilsException e){
  1745.                 // Controllo pre-esistenza dell'accordo
  1746.                 if( "404".equals(e.getMessage()) ){
  1747.                     throw new DriverRegistroServiziNotFound("[getSoggetto] Soggetto richiesto non esiste nel repository http: "+idSoggetto);
  1748.                 } else
  1749.                     throw e;
  1750.             }
  1751.             
  1752.             /* --- Validazione XSD (ora che sono sicuro che non ho un 404) -- */
  1753.             try{
  1754.                 this.validatoreRegistro.valida(urlXMLSoggetto);  
  1755.             }catch (Exception e) {
  1756.                 throw new DriverRegistroServiziException("[getSoggetto] Riscontrato errore durante la validazione XSD del soggetto("+idSoggetto+"): "+e.getMessage(),e);
  1757.             }
  1758.             
  1759.             // parsing
  1760.             bin = new ByteArrayInputStream(fileXML);
  1761.             org.openspcoop2.core.registry.utils.serializer.JaxbDeserializer deserializer = new org.openspcoop2.core.registry.utils.serializer.JaxbDeserializer();
  1762.             org.openspcoop2.core.registry.RegistroServizi rs = 
  1763.                 (org.openspcoop2.core.registry.RegistroServizi) deserializer.readRegistroServizi(bin);
  1764.             if(rs.sizeSoggettoList()>0)
  1765.                 soggRichiesto = rs.getSoggetto(0);
  1766.             bin.close();
  1767.         }catch(Exception e){
  1768.             try{
  1769.                 if(bin!=null)
  1770.                     bin.close();
  1771.             } catch(Exception eis) {
  1772.                 // ignore
  1773.             }
  1774.             if(e instanceof DriverRegistroServiziNotFound)
  1775.                 throw (DriverRegistroServiziNotFound)e;
  1776.             else
  1777.                 throw new DriverRegistroServiziException("[getSoggetto] Errore durante il parsing xml del soggetto("+idSoggetto+"): "+e.getMessage(),e);
  1778.         }

  1780.         if(soggRichiesto==null)
  1781.             throw new DriverRegistroServiziNotFound("[getSoggetto] Soggetto ["+idSoggetto+"] non trovato.");
  1782.         
  1783.         return soggRichiesto;
  1784.     }

  1786.     @Override
  1787.     public Soggetto getSoggettoByCredenzialiBasic(
  1788.             String user,String password, 
  1789.             CryptConfig config) throws DriverRegistroServiziException, DriverRegistroServiziNotFound{
  1790.         return this.getEngineSoggettoAutenticato(CredenzialeTipo.BASIC, user, password, 
  1791.                 null, null, null, false,
  1792.                 null,
  1793.                 config,
  1794.                 false);
  1795.     }
  1796.     
  1797.     @Override
  1798.     public Soggetto getSoggettoByCredenzialiApiKey(
  1799.             String user,String password, boolean appId,
  1800.             CryptConfig config) throws DriverRegistroServiziException, DriverRegistroServiziNotFound{
  1801.         return this.getEngineSoggettoAutenticato(CredenzialeTipo.BASIC, user, password, 
  1802.                 null, null, null, false,
  1803.                 null,
  1804.                 config,
  1805.                 appId);
  1806.     }
  1807.     
  1808.     @Override
  1809.     public Soggetto getSoggettoByCredenzialiSsl(
  1810.             String subject, String issuer) throws DriverRegistroServiziException, DriverRegistroServiziNotFound{
  1811.         return this.getEngineSoggettoAutenticato(CredenzialeTipo.SSL, null, null, 
  1812.                 subject, issuer, null, false,
  1813.                 null,
  1814.                 null,
  1815.                 false);
  1816.     }
  1817.     
  1818.     @Override
  1819.     public Soggetto getSoggettoByCredenzialiSsl(CertificateInfo certificate, boolean strictVerifier) throws DriverRegistroServiziException,DriverRegistroServiziNotFound{
  1820.         return this.getEngineSoggettoAutenticato(CredenzialeTipo.SSL, null, null, 
  1821.                 null, null, certificate, strictVerifier,
  1822.                 null,
  1823.                 null,
  1824.                 false);
  1825.     }
  1826.     
  1827.     @Override
  1828.     public Soggetto getSoggettoByCredenzialiPrincipal(
  1829.             String principal) throws DriverRegistroServiziException, DriverRegistroServiziNotFound{
  1830.         return this.getEngineSoggettoAutenticato(CredenzialeTipo.PRINCIPAL, null, null, 
  1831.                 null, null, null, false,
  1832.                 principal,
  1833.                 null,
  1834.                 false);
  1835.     }
  1836.     private org.openspcoop2.core.registry.Soggetto getEngineSoggettoAutenticato(CredenzialeTipo tipoCredenziale, String user,String password, 
  1837.             String aSubject, String aIssuer, CertificateInfo aCertificate, boolean aStrictVerifier, 
  1838.             String principal, 
  1839.             CryptConfig config,
  1840.             boolean appId) throws DriverRegistroServiziException,DriverRegistroServiziNotFound{

  1842.         // conrollo consistenza
  1843.         if (tipoCredenziale == null)
  1844.             throw new DriverRegistroServiziException("[getSoggettoAutenticato] Parametro tipoCredenziale is null");

  1846.         switch (tipoCredenziale) {
  1847.         case BASIC:
  1848.             if (user == null || "".equalsIgnoreCase(user))
  1849.                 throw new DriverRegistroServiziException("[getSoggettoAutenticato] Parametro user is null (required for basic auth)");
  1850.             if (password == null || "".equalsIgnoreCase(password))
  1851.                 throw new DriverRegistroServiziException("[getSoggettoAutenticato] Parametro password is null (required for basic auth)");
  1852.             break;
  1853.         case APIKEY:
  1854.             if (user == null || "".equalsIgnoreCase(user))
  1855.                 throw new DriverRegistroServiziException("[getSoggettoAutenticato] Parametro user is null (required for apikey auth)");
  1856.             if (password == null || "".equalsIgnoreCase(password))
  1857.                 throw new DriverRegistroServiziException("[getSoggettoAutenticato] Parametro password is null (required for apikey auth)");
  1858.             break;
  1859.         case SSL:
  1860.             if ( (aSubject == null || "".equalsIgnoreCase(aSubject)) && (aCertificate==null))
  1861.                 throw new DriverRegistroServiziException("[getSoggettoAutenticato] Parametro subject/certificate is null (required for ssl auth)");
  1862.             break;
  1863.         case PRINCIPAL:
  1864.             if (principal == null || "".equalsIgnoreCase(principal))
  1865.                 throw new DriverRegistroServiziException("[getSoggettoAutenticato] Parametro principal is null (required for principal auth)");
  1866.             break;
  1867.         }

  1869.         IDSoggetto idSoggetto = null;
  1870.         try{
  1871.             FiltroRicercaSoggetti filtroRicerca = new FiltroRicercaSoggetti();
  1872.             CredenzialiSoggetto credenzialiSoggetto = new CredenzialiSoggetto();
  1873.             credenzialiSoggetto.setTipo(tipoCredenziale);
  1874.             switch (tipoCredenziale) {
  1875.             case BASIC:
  1876.                 credenzialiSoggetto.setUser(user);
  1877.                 credenzialiSoggetto.setPassword(password);
  1878.                 break;
  1879.             case APIKEY:
  1880.                 credenzialiSoggetto.setUser(user);
  1881.                 credenzialiSoggetto.setPassword(password);
  1882.                 credenzialiSoggetto.setAppId(appId);
  1883.                 break;
  1884.             case SSL:
  1885.                 credenzialiSoggetto.setSubject(aSubject);
  1886.                 credenzialiSoggetto.setIssuer(aIssuer);
  1887.                 if(aCertificate!=null) {
  1888.                     try {
  1889.                         credenzialiSoggetto.setCertificate(aCertificate.getCertificate().getEncoded());
  1890.                     }catch(Exception e) {
  1891.                         throw new DriverRegistroServiziException(e.getMessage(),e);
  1892.                     }
  1893.                 }
  1894.                 credenzialiSoggetto.setCertificateStrictVerification(aStrictVerifier);
  1895.                 break;
  1896.             case PRINCIPAL:
  1897.                 credenzialiSoggetto.setUser(principal);
  1898.                 break;
  1899.             }
  1900.             filtroRicerca.setCredenzialiSoggetto(credenzialiSoggetto, config);
  1901.             List<IDSoggetto> l = this.getAllIdSoggetti(filtroRicerca);
  1902.             if(l.size()>1){
  1903.                 throw new DriverRegistroServiziException("Trovato più di un soggetto che possiede le credenziali '"+tipoCredenziale.toString()+"' fornite");
  1904.             }
  1905.             else if(l.size()==1){
  1906.                 idSoggetto = l.get(0);
  1907.             }
  1908.         }catch(DriverRegistroServiziNotFound notFound){
  1909.             // ignore
  1910.         }
  1911.         
  1912.         if(idSoggetto==null){
  1913.             throw new DriverRegistroServiziNotFound("Nessun soggetto trovato che possiede le credenziali '"+tipoCredenziale.toString()+"' fornite");
  1914.         }
  1915.         else{
  1916.             return this.getSoggetto(idSoggetto);
  1917.         }
  1918.     }
  1919.     
  1920.     /**
  1921.      *  Ritorna gli identificatori dei soggetti che rispettano il parametro di ricerca
  1922.      * 
  1923.      * @param filtroRicerca
  1924.      * @return Una lista di ID dei soggetti trovati
  1925.      * @throws DriverRegistroServiziException
  1926.      * @throws DriverRegistroServiziNotFound
  1927.      */
  1928.     @Override
  1929.     public List<IDSoggetto> getAllIdSoggetti(FiltroRicercaSoggetti filtroRicerca) throws DriverRegistroServiziException,DriverRegistroServiziNotFound{
  1930.         try{
  1931.             // Ricerca UDDI dei soggetti
  1932.             String [] urlXMLSoggetti = this.uddiLib.getUrlXmlSoggetti();
  1933.             
  1934.             boolean testInChiaro = false;
  1935.             ICrypt crypt = null;
  1936.             if(filtroRicerca!=null && filtroRicerca.getCredenzialiSoggetto()!=null && filtroRicerca.getCredenzialiSoggetto().getPassword()!=null){
  1937.                 CredenzialeTipo cTipo = filtroRicerca.getCredenzialiSoggetto().getTipo();
  1938.                 if(CredenzialeTipo.BASIC.equals(cTipo)){
  1939.                     CryptConfig config = filtroRicerca.getCryptConfig();
  1940.                     if(config==null || config.isBackwardCompatibility()) {
  1941.                         testInChiaro = true;
  1942.                     }
  1943.                     if(config!=null) {
  1944.                         try {
  1945.                             crypt = CryptFactory.getCrypt(this.log, config);
  1946.                         }catch(Exception e) {
  1947.                             throw new DriverRegistroServiziException(e.getMessage(),e);
  1948.                         }
  1949.                     }
  1950.                 }
  1951.                 else if(CredenzialeTipo.APIKEY.equals(cTipo)){
  1952.                     CryptConfig config = filtroRicerca.getCryptConfig();
  1953.                     if(config!=null) {
  1954.                         try {
  1955.                             crypt = CryptFactory.getCrypt(this.log, config);
  1956.                         }catch(Exception e) {
  1957.                             throw new DriverRegistroServiziException(e.getMessage(),e);
  1958.                         }
  1959.                     }
  1960.                     else {
  1961.                         testInChiaro = true;
  1962.                     }
  1963.                 }
  1964.             }
  1965.             
  1966.             // Esamina dei soggetti
  1967.             List<IDSoggetto> idSoggetti = new ArrayList<IDSoggetto>();
  1968.             for(int i=0; i<urlXMLSoggetti.length; i++){
  1969.                 
  1970.                 org.openspcoop2.core.registry.Soggetto ss = null;
  1971.                 
  1972.                 /* --- Validazione XSD -- */
  1973.                 try{
  1974.                     this.validatoreRegistro.valida(urlXMLSoggetti[i]);  
  1975.                 }catch (Exception e) {
  1976.                     throw new DriverRegistroServiziException("[getAllIdSoggettiRegistro] Riscontrato errore durante la validazione XSD ("+urlXMLSoggetti[i]+"): "+e.getMessage(),e);
  1977.                 }
  1978.                 
  1979.                 // Ottengo oggetto Soggetto
  1980.                 ByteArrayInputStream bin = null;
  1981.                 try{
  1982.                     byte[] fileXML = HttpUtilities.requestHTTPFile(urlXMLSoggetti[i]);
  1983.                     bin = new ByteArrayInputStream(fileXML);
  1984.                     org.openspcoop2.core.registry.utils.serializer.JaxbDeserializer deserializer = new org.openspcoop2.core.registry.utils.serializer.JaxbDeserializer();
  1985.                     org.openspcoop2.core.registry.RegistroServizi rs = 
  1986.                         (org.openspcoop2.core.registry.RegistroServizi) deserializer.readRegistroServizi(bin);
  1987.                     if(rs.sizeSoggettoList()>0)
  1988.                         ss = rs.getSoggetto(0);
  1989.                     bin.close();
  1990.                 }catch(Exception e){
  1991.                     try{
  1992.                         if(bin!=null)
  1993.                             bin.close();
  1994.                     } catch(Exception eis) {
  1995.                         // ignore
  1996.                     }
  1997.                     throw new DriverRegistroServiziException("[getAllIdSoggettiRegistro] Errore durante il parsing xml ("+urlXMLSoggetti[i]+"): "+e.getMessage(),e);
  1998.                 }
  1999.                 if(ss==null)
  2000.                     throw new DriverRegistroServiziException("[getAllIdSoggettiRegistro] soggetto non definito per la url ["+urlXMLSoggetti[i]+"]");
  2001.                 
  2002.                 
  2003.                 if(filtroRicerca!=null){
  2004.                     // Filtro By Data
  2005.                     if(filtroRicerca.getMinDate()!=null){
  2006.                         if(ss.getOraRegistrazione()==null){
  2007.                             this.log.debug("[getAllIdSoggettiRegistro](FiltroByMinDate) Soggetto ["+ss.getTipo()+"/"+ss.getNome()+"] non valorizzato nell'ora-registrazione. Non inserito nella lista ritornata.");
  2008.                             continue;
  2009.                         }else if(ss.getOraRegistrazione().before(filtroRicerca.getMinDate())){
  2010.                             continue;
  2011.                         }
  2012.                     }
  2013.                     if(filtroRicerca.getMaxDate()!=null){
  2014.                         if(ss.getOraRegistrazione()==null){
  2015.                             this.log.debug("[getAllIdSoggettiRegistro](FiltroByMaxDate) Soggetto ["+ss.getTipo()+"/"+ss.getNome()+"] non valorizzato nell'ora-registrazione. Non inserito nella lista ritornata.");
  2016.                             continue;
  2017.                         }else if(ss.getOraRegistrazione().after(filtroRicerca.getMaxDate())){
  2018.                             continue;
  2019.                         }
  2020.                     }
  2021.                     // Filtro By Tipo e Nome
  2022.                     if(filtroRicerca.getTipo()!=null){
  2023.                         if(ss.getTipo().equals(filtroRicerca.getTipo()) == false){
  2024.                             continue;
  2025.                         }
  2026.                     }
  2027.                     if(filtroRicerca.getNome()!=null){
  2028.                         if(ss.getNome().equals(filtroRicerca.getNome()) == false){
  2029.                             continue;
  2030.                         }
  2031.                     }
  2032.                     // Filtro By Pdd
  2033.                     if(filtroRicerca.getNomePdd()!=null){
  2034.                         if(ss.getPortaDominio().equals(filtroRicerca.getNomePdd()) == false){
  2035.                             continue;
  2036.                         }
  2037.                     }
  2038.                     // ProtocolProperties
  2039.                     if(ProtocolPropertiesUtilities.isMatch(ss, filtroRicerca.getProtocolProperties())==false){
  2040.                         continue;
  2041.                     }
  2042.                     // Filtro By Ruoli
  2043.                     if(filtroRicerca.getIdRuolo()!=null && filtroRicerca.getIdRuolo().getNome()!=null){
  2044.                         if(ss.getRuoli()==null){
  2045.                             continue;
  2046.                         }
  2047.                         boolean contains = false;
  2048.                         for (int j = 0; j < ss.getRuoli().sizeRuoloList(); j++) {
  2049.                             if(filtroRicerca.getIdRuolo().getNome().equals(ss.getRuoli().getRuolo(j).getNome())){
  2050.                                 contains = true;
  2051.                                 break;
  2052.                             }
  2053.                         }
  2054.                         if(!contains){
  2055.                             continue;
  2056.                         }
  2057.                     }
  2058.                     // Filtro By Credenziali
  2059.                     if(filtroRicerca.getCredenzialiSoggetto()!=null){
  2060.                         CredenzialiSoggetto credenziali = (ss.sizeCredenzialiList() > 0 ? ss.getCredenziali(0) : null);
  2061.                         if(credenziali==null){
  2062.                             continue;
  2063.                         }
  2064.                         if(filtroRicerca.getCredenzialiSoggetto().getTipo()!=null){
  2065.                             if(credenziali.getTipo()==null){
  2066.                                 if(filtroRicerca.getCredenzialiSoggetto().getTipo().equals(CredenzialeTipo.SSL) == false){ // ssl è il default
  2067.                                     continue;
  2068.                                 }   
  2069.                             }
  2070.                             else{
  2071.                                 if(filtroRicerca.getCredenzialiSoggetto().getTipo().equals(credenziali.getTipo())==false){
  2072.                                     continue;
  2073.                                 }
  2074.                                 if(CredenzialeTipo.APIKEY.equals(filtroRicerca.getCredenzialiSoggetto().getTipo())){
  2075.                                     if(filtroRicerca.getCredenzialiSoggetto().isAppId()) {
  2076.                                         if(!credenziali.isAppId()) {
  2077.                                             continue;
  2078.                                         }
  2079.                                     }
  2080.                                     else {
  2081.                                         if(credenziali.isAppId()) {
  2082.                                             continue;
  2083.                                         }
  2084.                                     }
  2085.                                 }
  2086.                             }
  2087.                         }
  2088.                         if(filtroRicerca.getCredenzialiSoggetto().getUser()!=null){
  2089.                             if(filtroRicerca.getCredenzialiSoggetto().getUser().equals(credenziali.getUser())==false){
  2090.                                 continue;
  2091.                             }
  2092.                         }
  2093.                         if(filtroRicerca.getCredenzialiSoggetto().getPassword()!=null){
  2094.                             String passwordSaved =  credenziali.getPassword();
  2095.                             boolean found = false;
  2096.                             if(testInChiaro) {
  2097.                                 found = filtroRicerca.getCredenzialiSoggetto().getPassword().equals(passwordSaved);
  2098.                             }
  2099.                             if(!found && crypt!=null) {
  2100.                                 found = crypt.check(filtroRicerca.getCredenzialiSoggetto().getPassword(), passwordSaved);
  2101.                             }
  2102.                             
  2103.                             if( !found ) {
  2104.                                 continue;
  2105.                             }
  2106.                         }
  2107.                         if(filtroRicerca.getCredenzialiSoggetto().getSubject()!=null){
  2108.                             try{
  2109.                                 if(credenziali.getSubject()==null){
  2110.                                     continue;
  2111.                                 }
  2112.                                 boolean subjectValid = CertificateUtils.sslVerify(credenziali.getSubject(), filtroRicerca.getCredenzialiSoggetto().getSubject(), PrincipalType.SUBJECT, this.log);
  2113.                                 boolean issuerValid = true;
  2114.                                 if(filtroRicerca.getCredenzialiSoggetto().getIssuer()!=null) {
  2115.                                     issuerValid = CertificateUtils.sslVerify(credenziali.getIssuer(), filtroRicerca.getCredenzialiSoggetto().getIssuer(), PrincipalType.ISSUER, this.log);
  2116.                                 }
  2117.                                 else {
  2118.                                     issuerValid = (credenziali.getIssuer() == null);
  2119.                                 }
  2120.                                 if(!subjectValid || !issuerValid){
  2121.                                     continue;
  2122.                                 }
  2123.                             }catch(Exception e){
  2124.                                 throw new DriverRegistroServiziException(e.getMessage(),e);
  2125.                             }
  2126.                         }
  2127.                         if(filtroRicerca.getCredenzialiSoggetto().getCnSubject()!=null && filtroRicerca.getCredenzialiSoggetto().getCertificate()!=null) {
  2128.                             if(filtroRicerca.getCredenzialiSoggetto().getCnSubject().equals(credenziali.getCnSubject())==false) {
  2129.                                 continue;
  2130.                             }
  2131.                             // Possono esistere piu' soggetti che hanno un CN con subject e issuer diverso.
  2132.                             Certificate certificato = ArchiveLoader.load(ArchiveType.CER, credenziali.getCertificate(), 0, null);
  2133.                             Certificate certificatoFiltro = ArchiveLoader.load(ArchiveType.CER, filtroRicerca.getCredenzialiSoggetto().getCertificate(), 0, null);                          
  2134.                             if(!certificatoFiltro.getCertificate().equals(certificato.getCertificate(),filtroRicerca.getCredenzialiSoggetto().isCertificateStrictVerification())) {
  2135.                                 continue;
  2136.                             }
  2137.                         }
  2138.                     }
  2139.                 }
  2140.                 IDSoggetto idS = new IDSoggetto(ss.getTipo(),ss.getNome());
  2141.                 idSoggetti.add(idS);
  2142.             }
  2143.             if(idSoggetti.size()==0){
  2144.                 throw new DriverRegistroServiziNotFound("Soggetti non trovati che rispettano il filtro di ricerca selezionato: "+filtroRicerca.toString());
  2145.             }else{
  2146.                 return idSoggetti;
  2147.             }
  2148.         }catch(Exception e){
  2149.             if(e instanceof DriverRegistroServiziNotFound)
  2150.                 throw (DriverRegistroServiziNotFound)e;
  2151.             else
  2152.                 throw new DriverRegistroServiziException("getAllIdSoggettiRegistro error",e);
  2153.         }
  2154.     }
  2155.     
  2156.     
  2157.     
  2158.     
  2159.     
  2160.     
  2161.     /* Accordi di Servizio Parte Specifica */
  2162.     
  2163.     /**
  2164.      * Si occupa di ritornare l'oggetto {@link org.openspcoop2.core.registry.AccordoServizioParteSpecifica}
  2165.      * contenente le informazioni sulle funzionalita' associate
  2166.      * al servizio  identificato grazie ai fields Soggetto,
  2167.      * 'Servizio','TipoServizio' e 'Azione' impostati
  2168.      * all'interno del parametro <var>idService</var> di tipo {@link org.openspcoop2.core.id.IDServizio}. 
  2169.      *
  2170.      * @param idServizio Identificatore del Servizio di tipo {@link org.openspcoop2.core.id.IDServizio}.
  2171.      * @return l'oggetto di tipo {@link org.openspcoop2.core.registry.AccordoServizioParteSpecifica} 
  2172.      * 
  2173.      */
  2174.     @Override
  2175.     public org.openspcoop2.core.registry.AccordoServizioParteSpecifica getAccordoServizioParteSpecifica(IDServizio idServizio) throws DriverRegistroServiziException,DriverRegistroServiziNotFound{
  2176.         
  2177.         if(idServizio == null || idServizio.getSoggettoErogatore()==null)
  2178.             throw new DriverRegistroServiziException("[getAccordoServizioParteSpecifica] Parametro Non Valido");
  2179.         
  2180.         // controllo inizializzazione UDDI
  2181.         if(this.uddiLib.create == false){
  2182.             throw new DriverRegistroServiziException("[getAccordoServizioParteSpecifica] Inizializzazione dell'engine UDDI errata");
  2183.         }
  2184.         
  2185.         //  Controllo pre-esistenza del soggetto
  2186.         if( this.uddiLib.existsSoggetto(idServizio.getSoggettoErogatore()) == false){
  2187.             throw new DriverRegistroServiziNotFound("[getAccordoServizioParteSpecifica] Il soggetto ["+idServizio.getSoggettoErogatore()
  2188.             +"] non risulta gia' inserito nel registro dei servizi.");
  2189.         } 
  2190.         // Controllo pre-esistenza del servizio
  2191.         if (this.uddiLib.existsServizio(idServizio)==false){
  2192.             throw new DriverRegistroServiziNotFound("[getAccordoServizioParteSpecifica] Il servizio ["+idServizio.toString()+"] non risulta gia' registrato nel registro");
  2193.         }
  2194.         
  2195.         org.openspcoop2.core.registry.AccordoServizioParteSpecifica servRichiesto = null;
  2196.         // get URL XML Servizio
  2197.         String urlXMLServizio = this.uddiLib.getUrlXmlServizio(idServizio);
  2198.         if( urlXMLServizio == null ){
  2199.             throw new DriverRegistroServiziException("[getAccordoServizioParteSpecifica] Definizione XML non disponibile");
  2200.         }
  2201.         
  2202.         ByteArrayInputStream bin = null;
  2203.         try{
  2204.             byte[] fileXML = null;
  2205.             try{
  2206.                 fileXML = HttpUtilities.requestHTTPFile(urlXMLServizio);
  2207.             }catch(UtilsException e){
  2208.                 // Controllo pre-esistenza dell'accordo
  2209.                 if( "404".equals(e.getMessage()) ){
  2210.                     throw new DriverRegistroServiziNotFound("[getAccordoServizioParteSpecifica] Servizio richiesto non esiste nel repository http: "+idServizio);
  2211.                 } else
  2212.                     throw e;
  2213.             }
  2214.             
  2215.             /* --- Validazione XSD (ora che sono sicuro che non ho un 404) -- */
  2216.             try{
  2217.                 this.validatoreRegistro.valida(urlXMLServizio);  
  2218.             }catch (Exception e) {
  2219.                 throw new DriverRegistroServiziException("[getAccordoServizioParteSpecifica] Riscontrato errore durante la validazione XSD del servizio("+idServizio+"): "+e.getMessage(),e);
  2220.             }
  2221.             
  2222.             // parsing
  2223.             bin = new ByteArrayInputStream(fileXML);
  2224.             org.openspcoop2.core.registry.utils.serializer.JaxbDeserializer deserializer = new org.openspcoop2.core.registry.utils.serializer.JaxbDeserializer();
  2225.             org.openspcoop2.core.registry.RegistroServizi rs = 
  2226.                 (org.openspcoop2.core.registry.RegistroServizi) deserializer.readRegistroServizi(bin);
  2227.             if(rs.sizeSoggettoList()>0){
  2228.                 if(rs.getSoggetto(0).sizeAccordoServizioParteSpecificaList()>0){
  2229.                     servRichiesto = rs.getSoggetto(0).getAccordoServizioParteSpecifica(0);
  2230.                     servRichiesto.setNomeSoggettoErogatore(idServizio.getSoggettoErogatore().getNome());
  2231.                     servRichiesto.setTipoSoggettoErogatore(idServizio.getSoggettoErogatore().getTipo());
  2232.                 }
  2233.             }
  2234.             bin.close();
  2235.         }catch(Exception e){
  2236.             try{
  2237.                 if(bin!=null)
  2238.                     bin.close();
  2239.             } catch(Exception eis) {
  2240.                 // ignore
  2241.             }
  2242.             if(e instanceof DriverRegistroServiziNotFound)
  2243.                 throw (DriverRegistroServiziNotFound)e;
  2244.             else
  2245.                 throw new DriverRegistroServiziException("[getAccordoServizioParteSpecifica] Errore durante il parsing xml del servizio("+idServizio+"): "+e.getMessage(),e);
  2246.         }

  2248.         if(servRichiesto==null)
  2249.             throw new DriverRegistroServiziNotFound("[getAccordoServizioParteSpecifica] Servizio non trovato.");
  2250.             
  2251.         return servRichiesto;
  2252.     }
  2253.     
  2254.     
  2255.     
  2256.     /**
  2257.      * Si occupa di ritornare l'oggetto {@link org.openspcoop2.core.registry.AccordoServizioParteSpecifica}
  2258.      * contenente le informazioni sulle funzionalita' associate
  2259.      * al servizio  correlato identificato grazie ai fields Soggetto
  2260.      * e nomeAccordo
  2261.      * 
  2262.      * @param idSoggetto Identificatore del Soggetto di tipo {@link org.openspcoop2.core.id.IDSoggetto}.
  2263.      * @param idAccordo ID dell'accordo che deve implementare il servizio correlato
  2264.      * @return l'oggetto di tipo {@link org.openspcoop2.core.registry.AccordoServizioParteSpecifica} 
  2265.      * 
  2266.      */
  2267.     @Override
  2268.     public org.openspcoop2.core.registry.AccordoServizioParteSpecifica getAccordoServizioParteSpecifica_ServizioCorrelato(IDSoggetto idSoggetto, IDAccordo idAccordo) throws DriverRegistroServiziException,DriverRegistroServiziNotFound{

  2270.         if(idSoggetto == null || idAccordo==null || idAccordo.getNome()==null )
  2271.             throw new DriverRegistroServiziException("[getAccordoServizioParteSpecifica_ServizioCorrelato] Parametro Non Valido");
  2272.         
  2273.         //       controllo inizializzazione UDDI
  2274.         if(this.uddiLib.create == false){
  2275.             throw new DriverRegistroServiziException("[getAccordoServizioParteSpecifica_ServizioCorrelato] Inizializzazione dell'engine UDDI errata");
  2276.         }
  2277.         
  2278.         //  Controllo pre-esistenza del soggetto
  2279.         if( this.uddiLib.existsSoggetto(idSoggetto) == false){
  2280.             throw new DriverRegistroServiziNotFound("Il soggetto ["+idSoggetto
  2281.             +"] non risulta gia' inserito nel registro dei servizi.");
  2282.         } 
  2283.                 
  2284.         String [] url =  this.uddiLib.getUrlXmlServizi(idSoggetto,idAccordo);
  2285.         if(url==null)
  2286.             throw new DriverRegistroServiziNotFound("[getAccordoServizioParteSpecifica_ServizioCorrelato] Servizi correlati che rispettano il parametri di ricerca, non esistenti.");
  2287.         
  2288.         
  2289.         org.openspcoop2.core.registry.AccordoServizioParteSpecifica servCorrelatoRichiesto = null;
  2290.         for(int i=0; i<url.length; i++){
  2291.             
  2292.             //System.out.println("URL["+(i+1)+"]: "+url[i]);    
  2293.             ByteArrayInputStream bin = null;
  2294.             try{
  2295.                 byte[] fileXML = null;
  2296.                 try{
  2297.                     fileXML = HttpUtilities.requestHTTPFile(url[i]);
  2298.                 }catch(UtilsException e){
  2299.                     // Controllo pre-esistenza dell'accordo
  2300.                     if( "404".equals(e.getMessage()) ){
  2301.                         throw new DriverRegistroServiziNotFound("[getAccordoServizioParteSpecifica_ServizioCorrelato] Servizio richiesto non esiste nel repository http, accordo:"+idAccordo+ " e soggetto:"+idSoggetto);
  2302.                     } else
  2303.                         throw e;
  2304.                 }
  2305.                 
  2306.                 /* --- Validazione XSD (ora che sono sicuro che non ho un 404) -- */
  2307.                 try{
  2308.                     this.validatoreRegistro.valida(url[i]);  
  2309.                 }catch (Exception e) {
  2310.                     throw new DriverRegistroServiziException("[getAccordoServizioParteSpecifica_ServizioCorrelato] Riscontrato errore durante la validazione XSD del servizioUrl("+url[i]+"): "+e.getMessage(),e);
  2311.                 }
  2312.                 
  2313.                 // parsing
  2314.                 bin = new ByteArrayInputStream(fileXML);
  2315.                 org.openspcoop2.core.registry.utils.serializer.JaxbDeserializer deserializer = new org.openspcoop2.core.registry.utils.serializer.JaxbDeserializer();
  2316.                 org.openspcoop2.core.registry.RegistroServizi rs = 
  2317.                     (org.openspcoop2.core.registry.RegistroServizi) deserializer.readRegistroServizi(bin);
  2318.                 if(rs.sizeSoggettoList()>0){
  2319.                     if(rs.getSoggetto(0).sizeAccordoServizioParteSpecificaList()>0){
  2320.                         servCorrelatoRichiesto = rs.getSoggetto(0).getAccordoServizioParteSpecifica(0);
  2321.                         servCorrelatoRichiesto.setNomeSoggettoErogatore(idSoggetto.getNome());
  2322.                         servCorrelatoRichiesto.setTipoSoggettoErogatore(idSoggetto.getTipo());
  2323.                     }
  2324.                 }
  2325.                 bin.close();
  2326.                 if(servCorrelatoRichiesto!=null)
  2327.                     break;
  2328.             }catch(Exception e){
  2329.                 try{
  2330.                     if(bin!=null)
  2331.                         bin.close();
  2332.                 } catch(Exception eis) {
  2333.                     // ignore
  2334.                 }
  2335.                 if(e instanceof DriverRegistroServiziNotFound)
  2336.                     throw (DriverRegistroServiziNotFound)e;
  2337.                 else
  2338.                     throw new DriverRegistroServiziException("[getAccordoServizioParteSpecifica_ServizioCorrelato] Errore durante il parsing xml del servizioUrl("+url[i]+"): "+e.getMessage(),e);
  2339.             }
  2340.         }

  2342.         if(servCorrelatoRichiesto==null)
  2343.             throw new DriverRegistroServiziNotFound("[getAccordoServizioParteSpecifica_ServizioCorrelato] Servizio non trovato.");
  2344.             
  2345.         return servCorrelatoRichiesto;
  2346.     }

  2348.     
  2349.     @Override
  2350.     public List<IDServizio> getAllIdServizi(FiltroRicercaServizi filtroRicerca) throws DriverRegistroServiziException, DriverRegistroServiziNotFound{
  2351.         
  2352.         List<IDServizio> list = new ArrayList<IDServizio>();
  2353.         _fillAllIdServiziEngine("getAllIdServizi", filtroRicerca, list);
  2354.         return list;
  2355.         
  2356.     }
  2357.     
  2358.     @Override
  2359.     public List<IDFruizione> getAllIdFruizioniServizio(
  2360.             FiltroRicercaFruizioniServizio filtroRicerca) throws DriverRegistroServiziException, DriverRegistroServiziNotFound{
  2361.     
  2362.         List<IDFruizione> list = new ArrayList<IDFruizione>();
  2363.         _fillAllIdServiziEngine("getAllIdFruizioniServizio", filtroRicerca, list);
  2364.         return list;
  2365.         
  2366.     }
  2367.     
  2368.     @SuppressWarnings("unchecked")
  2369.     public <T> void _fillAllIdServiziEngine(String nomeMetodo, 
  2370.             FiltroRicercaServizi filtroRicerca,
  2371.             List<T> listReturn) throws DriverRegistroServiziException,DriverRegistroServiziNotFound{
  2372.             
  2373.         try{
  2374.     
  2375.             FiltroRicercaFruizioniServizio filtroFruizioni = null;
  2376.             if(filtroRicerca instanceof FiltroRicercaFruizioniServizio){
  2377.                 filtroFruizioni = (FiltroRicercaFruizioniServizio) filtroRicerca;
  2378.             }
  2379.             
  2380.             // Ricerca UDDI
  2381.             IDAccordo idAccordo = null;
  2382.             IDSoggetto soggettoErogatore = null;
  2383.             String tipoServizio = null;
  2384.             String nomeServizio = null;
  2385.             if(filtroRicerca!=null){
  2386.                 idAccordo = filtroRicerca.getIdAccordoServizioParteComune();
  2387.                 if(filtroRicerca.getTipoSoggettoErogatore()!=null && filtroRicerca.getNomeSoggettoErogatore()!=null){
  2388.                     soggettoErogatore = new IDSoggetto(filtroRicerca.getTipoSoggettoErogatore(),filtroRicerca.getNomeSoggettoErogatore());
  2389.                 }
  2390.                 tipoServizio = filtroRicerca.getTipo();
  2391.                 nomeServizio = filtroRicerca.getNome();
  2392.             }
  2393.             String [] urlXMLServizi = this.uddiLib.getUrlXMLServiziBySearch(idAccordo, soggettoErogatore, tipoServizio, nomeServizio);
  2394.             
  2395.             
  2396.             
  2397.             // Esamina dei servizi
  2398.             for(int i=0; i<urlXMLServizi.length; i++){
  2399.             
  2400.                 org.openspcoop2.core.registry.AccordoServizioParteSpecifica serv = null;
  2401.                 
  2402.                 /* --- Validazione XSD -- */
  2403.                 try{
  2404.                     this.validatoreRegistro.valida(urlXMLServizi[i]);  
  2405.                 }catch (Exception e) {
  2406.                     throw new DriverRegistroServiziException("[getAllIdServizi] Riscontrato errore durante la validazione XSD URL("+urlXMLServizi[i]+"): "+e.getMessage(),e);
  2407.                 }
  2408.                 
  2409.                 ByteArrayInputStream bin = null;
  2410.                 try{
  2411.                     byte[] fileXML = HttpUtilities.requestHTTPFile(urlXMLServizi[i]);
  2412.                     bin = new ByteArrayInputStream(fileXML);
  2413.                     org.openspcoop2.core.registry.utils.serializer.JaxbDeserializer deserializer = new org.openspcoop2.core.registry.utils.serializer.JaxbDeserializer();
  2414.                     org.openspcoop2.core.registry.RegistroServizi rs = 
  2415.                         (org.openspcoop2.core.registry.RegistroServizi) deserializer.readRegistroServizi(bin);
  2416.                     if(rs.sizeSoggettoList()>0){
  2417.                         if(rs.getSoggetto(0).sizeAccordoServizioParteSpecificaList()>0 ){
  2418.                             org.openspcoop2.core.registry.Soggetto s = rs.getSoggetto(0);
  2419.                             if(s.sizeAccordoServizioParteSpecificaList()>0){
  2420.                                 serv = s.getAccordoServizioParteSpecifica(0);
  2421.                                 serv.setNomeSoggettoErogatore(s.getNome());
  2422.                                 serv.setTipoSoggettoErogatore(s.getTipo());
  2423.                             }else{
  2424.                                 continue;
  2425.                             }
  2426.                         }
  2427.                     }
  2428.                     bin.close();
  2429.                 }catch(Exception e){
  2430.                     try{
  2431.                         if(bin!=null)
  2432.                             bin.close();
  2433.                     } catch(Exception eis) {
  2434.                         // ignore
  2435.                     }
  2436.                     throw new DriverRegistroServiziException("[getAllIdServizi] Errore durante il parsing xml del servizio("+urlXMLServizi[i]+"): "+e.getMessage(),e);
  2437.                 }
  2438.                 if(serv==null)
  2439.                     throw new DriverRegistroServiziException("[getAllIdServizi] servizio non definito per la url ["+urlXMLServizi[i]+"]");
  2440.                 
  2441.                 if(filtroRicerca!=null){
  2442.                     // Filtro By Tipo e Nome Soggetto Erogatore
  2443.                     if(filtroRicerca.getTipoSoggettoErogatore()!=null){
  2444.                         if(serv.getTipoSoggettoErogatore().equals(filtroRicerca.getTipoSoggettoErogatore()) == false){
  2445.                             continue;
  2446.                         }
  2447.                     }
  2448.                     if(filtroRicerca.getNomeSoggettoErogatore()!=null){
  2449.                         if(serv.getNomeSoggettoErogatore().equals(filtroRicerca.getNomeSoggettoErogatore()) == false){
  2450.                             continue;
  2451.                         }
  2452.                     }
  2453.                     // Filtro By Data
  2454.                     if(filtroRicerca.getMinDate()!=null){
  2455.                         if(serv.getOraRegistrazione()==null){
  2456.                             this.log.debug("[getAllIdServizi](FiltroByMinDate) ["+this.idServizioFactory.getUriFromAccordo(serv)+"] non valorizzato nell'ora-registrazione. Non inserito nella lista ritornata.");
  2457.                             continue;
  2458.                         }else if(serv.getOraRegistrazione().before(filtroRicerca.getMinDate())){
  2459.                             continue;
  2460.                         }
  2461.                     }
  2462.                     if(filtroRicerca.getMaxDate()!=null){
  2463.                         if(serv.getOraRegistrazione()==null){
  2464.                             this.log.debug("[getAllIdServizi](FiltroByMaxDate) Servizio["+this.idServizioFactory.getUriFromAccordo(serv)+"] non valorizzato nell'ora-registrazione. Non inserito nella lista ritornata.");
  2465.                             continue;
  2466.                         }else if(serv.getOraRegistrazione().after(filtroRicerca.getMaxDate())){
  2467.                             continue;
  2468.                         }
  2469.                     }
  2470.                     // Filtro By Tipo, Nome e Versione
  2471.                     if(filtroRicerca.getTipo()!=null){
  2472.                         if(serv.getTipo().equals(filtroRicerca.getTipo()) == false){
  2473.                             continue;
  2474.                         }
  2475.                     }
  2476.                     if(filtroRicerca.getNome()!=null){
  2477.                         if(serv.getNome().equals(filtroRicerca.getNome()) == false){
  2478.                             continue;
  2479.                         }
  2480.                     }
  2481.                     if(filtroRicerca.getVersione()!=null){
  2482.                         if(serv.getVersione().intValue() != filtroRicerca.getVersione().intValue()){
  2483.                             continue;
  2484.                         }
  2485.                     }
  2486.                     if(filtroRicerca.getPortType()!=null){
  2487.                         if(serv.getPortType().equals(filtroRicerca.getPortType()) == false){
  2488.                             continue;
  2489.                         }
  2490.                     }
  2491.                     // Filtro by Accordo
  2492.                     if(filtroRicerca.getIdAccordoServizioParteComune()!=null){
  2493.                         String uriAccordo = this.idAccordoFactory.getUriFromIDAccordo(filtroRicerca.getIdAccordoServizioParteComune());
  2494.                         if(serv.getAccordoServizioParteComune().equals(uriAccordo) == false){
  2495.                             continue;
  2496.                         }
  2497.                     }
  2498.                     // ProtocolProperties
  2499.                     if(ProtocolPropertiesUtilities.isMatch(serv, filtroRicerca.getProtocolProperties())==false){
  2500.                         continue;
  2501.                     }
  2502.                     // Filtro By Tipo e/o Nome Soggetto Fruitore
  2503.                     if(filtroRicerca.getTipoSoggettoFruitore()!=null || filtroRicerca.getNomeSoggettoFruitore()!=null){
  2504.                         if(serv.sizeFruitoreList()<=0){
  2505.                             continue;
  2506.                         }
  2507.                         boolean found = false;
  2508.                         for (int k = 0; k < serv.sizeFruitoreList(); k++) {
  2509.                             Fruitore fruitore = serv.getFruitore(k);
  2510.                             if(filtroRicerca.getTipoSoggettoFruitore()!=null){
  2511.                                 if(fruitore.getTipo().equals(filtroRicerca.getTipoSoggettoFruitore()) == false){
  2512.                                     continue;
  2513.                                 }
  2514.                             }
  2515.                             if(filtroRicerca.getNomeSoggettoFruitore()!=null){
  2516.                                 if(fruitore.getNome().equals(filtroRicerca.getNomeSoggettoFruitore()) == false){
  2517.                                     continue;
  2518.                                 }
  2519.                             }
  2520.                             found = true;
  2521.                             break;
  2522.                         }
  2523.                         if(!found){
  2524.                             continue;
  2525.                         }
  2526.                     }
  2527.                 }
  2528.                 
  2529.                 IDServizio idServ = this.idServizioFactory.getIDServizioFromAccordo(serv); 
  2530.                 
  2531.                 if(filtroFruizioni!=null){
  2532.                     
  2533.                     for (Fruitore fruitore : serv.getFruitoreList()) {
  2534.                         
  2535.                         // Tipo
  2536.                         if(filtroFruizioni.getTipoSoggettoFruitore()!=null){
  2537.                             if(fruitore.getTipo().equals(filtroFruizioni.getTipoSoggettoFruitore()) == false){
  2538.                                 continue;
  2539.                             }
  2540.                         }
  2541.                         // Nome
  2542.                         if(filtroFruizioni.getNomeSoggettoFruitore()!=null){
  2543.                             if(fruitore.getNome().equals(filtroFruizioni.getNomeSoggettoFruitore()) == false){
  2544.                                 continue;
  2545.                             }
  2546.                         }
  2547.                         // ProtocolProperties
  2548.                         if(ProtocolPropertiesUtilities.isMatch(fruitore, filtroFruizioni.getProtocolPropertiesFruizione())==false){
  2549.                             continue;
  2550.                         }
  2551.                         
  2552.                         IDFruizione idFruizione = new IDFruizione();
  2553.                         idFruizione.setIdServizio(idServ);
  2554.                         idFruizione.setIdFruitore(new IDSoggetto(fruitore.getTipo(), fruitore.getNome()));
  2555.                         listReturn.add((T)idFruizione);
  2556.                     }
  2557.                     
  2558.                 }
  2559.                 else{
  2560.                     listReturn.add((T)idServ);
  2561.                 }
  2562.             }
  2563.             if(listReturn.size()<=0){
  2564.                 String msgFiltro = "Elementi non trovati che rispettano il filtro di ricerca selezionato: ";
  2565.                 if(filtroFruizioni!=null){
  2566.                     throw new DriverRegistroServiziNotFound(msgFiltro+filtroFruizioni.toString());
  2567.                 }
  2568.                 else if(filtroRicerca!=null){
  2569.                     throw new DriverRegistroServiziNotFound(msgFiltro+filtroRicerca.toString());
  2570.                 }
  2571.                 else
  2572.                     throw new DriverRegistroServiziNotFound("Elementi non trovati");
  2573.             }

  2575.         }catch(Exception e){
  2576.             if(e instanceof DriverRegistroServiziNotFound)
  2577.                 throw (DriverRegistroServiziNotFound)e;
  2578.             else
  2579.                 throw new DriverRegistroServiziException("getAllIdServizi error",e);
  2580.         }
  2581.     }
  2582.     
  2583.     @Override
  2584.     public Documento getAllegato(IDServizio idASPS, String nome)throws DriverRegistroServiziException,DriverRegistroServiziNotFound{
  2585.         throw new DriverRegistroServiziException("Not Implemented");
  2586.     }
  2587.     @Override
  2588.     public Documento getSpecificaSemiformale(IDServizio idASPS, TipiDocumentoSemiformale tipo, String nome)throws DriverRegistroServiziException,DriverRegistroServiziNotFound{
  2589.         throw new DriverRegistroServiziException("Not Implemented");
  2590.     }
  2591.     @Override
  2592.     public Documento getSpecificaSicurezza(IDServizio idASPS, TipiDocumentoSicurezza tipo, String nome)throws DriverRegistroServiziException,DriverRegistroServiziNotFound{
  2593.         throw new DriverRegistroServiziException("Not Implemented");
  2594.     }
  2595.     @Override
  2596.     public Documento getSpecificaLivelloServizio(IDServizio idASPS, TipiDocumentoLivelloServizio tipo, String nome)throws DriverRegistroServiziException,DriverRegistroServiziNotFound{
  2597.         throw new DriverRegistroServiziException("Not Implemented");
  2598.     }
  2599.     
  2600.     
  2601.     
  2602.     
  2603.     
  2604.     
  2605.     
  2606.     
  2607.     
  2608.     
  2609.     
  2610.     
  2611.     
  2612.     
  2613.     /* ********  INTERFACCIA IDriverRegistroServiziCRUD ******** */ 
  2614.     
  2615.     /**
  2616.      * Crea un nuovo AccordoCooperazione
  2617.      * 
  2618.      * @param accordoCooperazione
  2619.      * @throws DriverRegistroServiziException
  2620.      */
  2621.     @Override
  2622.     public void createAccordoCooperazione(AccordoCooperazione accordoCooperazione) throws DriverRegistroServiziException{
  2623.         if( accordoCooperazione == null)
  2624.             throw new DriverRegistroServiziException("[createAccordoCooperazione] Parametro Non Valido");
  2625.         
  2626.         IDAccordoCooperazione idAccordo = null;
  2627.         try {

  2629.             idAccordo = this.idAccordoCooperazioneFactory.getIDAccordoFromAccordo(accordoCooperazione);

  2631.             // controllo inizializzazione UDDI
  2632.             if(this.uddiLib.create == false){
  2633.                 throw new DriverRegistroServiziException("Inizializzazione dell'engine UDDI errata");
  2634.             }

  2636.             // Controllo elementi obbligatori
  2637.             if( accordoCooperazione.getNome() == null ){
  2638.                 throw new DriverRegistroServiziException("Accordo Cooperazione non completamente definito nei parametri obbligatori");
  2639.             }

  2641.             // Controllo pre-esistenza dell'accordo
  2642.             if( this.uddiLib.existsAccordoCooperazione(idAccordo) == true){
  2643.                 throw new DriverRegistroServiziException("L'accordo di cooperazione ["+idAccordo
  2644.                 +"] risulta gia' inserito nel registro dei servizi.");
  2645.             } 

  2647.             // Generazione XML
  2648.             this.generatoreXML.createAccordoCooperazione(idAccordo,accordoCooperazione);
  2649.                 
  2650.             // Registrazione nel registro UDDI.
  2651.             String urlXML = this.urlPrefix + CostantiXMLRepository.ACCORDI_DI_COOPERAZIONE + CostantiRegistroServizi.URL_SEPARATOR + 
  2652.                 this.generatoreXML.mappingIDAccordoCooperazioneToFileName(this.idAccordoCooperazioneFactory.getIDAccordoFromAccordo(accordoCooperazione))  + ".xml";
  2653.             this.uddiLib.createAccordoCooperazione(idAccordo,urlXML);

  2655.         }catch (Exception e) {
  2656.             throw new DriverRegistroServiziException("[createAccordoCooperazione] Errore generatosi durante la creazione di un nuovo accordo di cooperazione ["+idAccordo+"]: "+e.getMessage(),e);
  2657.         }
  2658.     }
  2659.     
  2660.     /**
  2661.      * Verifica l'esistenza di un accordo registrato.
  2662.      *
  2663.      * @param idAccordo dell'accordo da verificare
  2664.      * @return true se l'accordo esiste, false altrimenti
  2665.      * @throws DriverRegistroServiziException
  2666.      */    
  2667.     @Override
  2668.     public boolean existsAccordoCooperazione(IDAccordoCooperazione idAccordo) throws DriverRegistroServiziException{
  2669.         if( idAccordo == null)
  2670.             return false;
  2671.         if( idAccordo.getNome() == null)
  2672.             return false;
  2673.         
  2674.         try{
  2675.             return this.uddiLib.existsAccordoCooperazione(idAccordo);
  2676.         }catch(Exception e){
  2677.             this.log.error("[existsAccordoCooperazione] Accordo non trovato: "+e.getMessage(),e);
  2678.             return false;
  2679.         }
  2680.     }
  2681.     
  2682.     /**
  2683.      * Aggiorna l'AccordoCooperazione con i nuovi valori.
  2684.      *  
  2685.      * @param accordoCooperazione
  2686.      * @throws DriverRegistroServiziException
  2687.      */
  2688.     @Override
  2689.     public void updateAccordoCooperazione(AccordoCooperazione accordoCooperazione) throws DriverRegistroServiziException{
  2690.         if( accordoCooperazione == null)
  2691.             throw new DriverRegistroServiziException("[updateAccordoCooperazione] Parametro Non Valido");
  2692.         
  2693.         IDAccordoCooperazione idAccordoOLD = null;
  2694.         if(accordoCooperazione.getOldIDAccordoForUpdate()!=null){
  2695.             idAccordoOLD = accordoCooperazione.getOldIDAccordoForUpdate();
  2696.         }else{
  2697.             idAccordoOLD = this.idAccordoCooperazioneFactory.getIDAccordoFromAccordo(accordoCooperazione);
  2698.         }

  2700.         try {

  2702.             // Controllo  dell'accordo da Modificare
  2703.             if(idAccordoOLD==null){
  2704.                 throw new DriverRegistroServiziException("Accordo Cooperazione da modificare non definito");
  2705.             }

  2707.             // controllo inizializzazione UDDI
  2708.             if(this.uddiLib.create == false){
  2709.                 throw new DriverRegistroServiziException("Inizializzazione dell'engine UDDI errata");
  2710.             }

  2712.             // Controllo elementi obbligatori dell'accordo modificato
  2713.             if( accordoCooperazione.getNome() == null){
  2714.                 throw new DriverRegistroServiziException("Accordo Cooperazione modificato non completamente definito nei parametri obbligatori");
  2715.             }

  2717.             // Controllo pre-esistenza dell'accordo da modificare
  2718.             if( this.uddiLib.existsAccordoCooperazione(idAccordoOLD) == false){
  2719.                 throw new DriverRegistroServiziException("L'accordo di cooperazione ["+idAccordoOLD
  2720.                 +"] non risulta gia' inserito nel registro dei servizi.");
  2721.             } 

  2723.             // Controllo non esistenza della nuova identita dell'accordo (se da modificare)
  2724.             IDAccordoCooperazione idAccordoNEW = this.idAccordoCooperazioneFactory.getIDAccordoFromAccordo(accordoCooperazione);
  2725.             if(idAccordoOLD.equals(idAccordoNEW) == false){
  2726.                 if( this.uddiLib.existsAccordoCooperazione(idAccordoNEW) == true){
  2727.                     throw new DriverRegistroServiziException("L'accordo di cooperazione ["+idAccordoNEW
  2728.                     +"] risulta gia' inserito nel registro dei servizi.");
  2729.                 } 
  2730.             }

  2732.             // Ri-Generazione XML
  2733.             this.generatoreXML.createAccordoCooperazione(idAccordoOLD,accordoCooperazione);
  2734.             
  2735.             // Modifica UDDI
  2736.             if(idAccordoOLD.equals(idAccordoNEW) == false){
  2737.                 String urlXML = this.urlPrefix + CostantiXMLRepository.ACCORDI_DI_COOPERAZIONE + CostantiRegistroServizi.URL_SEPARATOR + 
  2738.                     this.generatoreXML.mappingIDAccordoCooperazioneToFileName(idAccordoNEW)  + ".xml";
  2739.                 this.uddiLib.updateAccordoCooperazione(idAccordoOLD,idAccordoNEW,urlXML);
  2740.             }

  2742.         }catch (Exception e) {
  2743.             throw new DriverRegistroServiziException("[updateAccordoCooperazione] Errore generatosi durante la modifica dell'accordo di cooperazione ["+idAccordoOLD+"]: "+e);
  2744.         }
  2745.     }
  2746.     
  2747.     /**
  2748.      * Elimina un AccordoCooperazione 
  2749.      *  
  2750.      * @param accordoCooperazione
  2751.      * @throws DriverRegistroServiziException
  2752.      */
  2753.     @Override
  2754.     public void deleteAccordoCooperazione(AccordoCooperazione accordoCooperazione) throws DriverRegistroServiziException{
  2755.         if( accordoCooperazione == null)
  2756.             throw new DriverRegistroServiziException("[deleteAccordoCooperazione] Parametro Non Valido");
  2757.                 
  2758.         IDAccordoCooperazione idAccordo = null;
  2759.         try {
  2760.             idAccordo = this.idAccordoCooperazioneFactory.getIDAccordoFromAccordo(accordoCooperazione);
  2761.             
  2762.             // controllo inizializzazione UDDI
  2763.             if(this.uddiLib.create == false){
  2764.                 throw new DriverRegistroServiziException("Inizializzazione dell'engine UDDI errata");
  2765.             }
  2766.         
  2767.             // Controllo id dell'accordo da eliminare
  2768.             if(accordoCooperazione.getNome()==null){
  2769.                 throw new DriverRegistroServiziException("Accordo Cooperazione da eliminare non definito");
  2770.             }

  2772.             // Controllo pre-esistenza dell'accordo da eliminare
  2773.             if( this.uddiLib.existsAccordoCooperazione(idAccordo) == false){
  2774.                 throw new DriverRegistroServiziException("L'accordo di cooperazione ["+idAccordo
  2775.                 +"] non risulta gia' inserito nel registro dei servizi.");
  2776.             } 

  2778.             // Delete from Repository
  2779.             this.generatoreXML.deleteAccordoCooperazione(idAccordo);
  2780.                 
  2781.             // Delete from UDDI
  2782.             this.uddiLib.deleteAccordoCooperazione(idAccordo);
  2783.             
  2784.         }catch (Exception e) {
  2785.             throw new DriverRegistroServiziException("[deleteAccordoCooperazione] Errore generatosi durante l'eliminazione dell'accordo di cooperazione ["+this.idAccordoCooperazioneFactory.getUriFromAccordo(accordoCooperazione)+"]: "+e.getMessage(),e);
  2786.         }
  2787.     }
  2788.     
  2789.     /**
  2790.      * Crea un nuovo AccordoServizio 
  2791.      * 
  2792.      * @param accordoServizio
  2793.      * @throws DriverRegistroServiziException
  2794.      */
  2795.     @Override
  2796.     public void createAccordoServizioParteComune(AccordoServizioParteComune accordoServizio) throws DriverRegistroServiziException{
  2797.         if( accordoServizio == null)
  2798.             throw new DriverRegistroServiziException("[createAccordoServizioParteComune] Parametro Non Valido");
  2799.         
  2800.         IDAccordo idAccordo = null;
  2801.         try {

  2803.             idAccordo = this.idAccordoFactory.getIDAccordoFromAccordo(accordoServizio);

  2805.             // controllo inizializzazione UDDI
  2806.             if(this.uddiLib.create == false){
  2807.                 throw new DriverRegistroServiziException("Inizializzazione dell'engine UDDI errata");
  2808.             }

  2810.             // Controllo elementi obbligatori
  2811.             if( (accordoServizio.getNome() == null) ||
  2812.                 (accordoServizio.getProfiloCollaborazione() == null) ){
  2813.                 throw new DriverRegistroServiziException("Accordo Servizio Parte Comune non completamente definito nei parametri obbligatori");
  2814.             }

  2816.             // Controllo pre-esistenza dell'accordo
  2817.             if( this.uddiLib.existsAccordoServizio(idAccordo) == true){
  2818.                 throw new DriverRegistroServiziException("L'accordo di servizio ["+idAccordo
  2819.                 +"] risulta gia' inserito nel registro dei servizi.");
  2820.             } 

  2822.             // Generazione XML
  2823.             this.generatoreXML.createAccordoServizioParteComune(idAccordo,accordoServizio);
  2824.                 
  2825.             // Registrazione nel registro UDDI.
  2826.             String urlXML = this.urlPrefix + CostantiXMLRepository.ACCORDI_DI_SERVIZIO + CostantiRegistroServizi.URL_SEPARATOR + 
  2827.                 this.generatoreXML.mappingIDAccordoToFileName(this.idAccordoFactory.getIDAccordoFromAccordo(accordoServizio))  + ".xml";
  2828.             this.uddiLib.createAccordoServizio(idAccordo,urlXML);

  2830.         }catch (Exception e) {
  2831.             throw new DriverRegistroServiziException("[createAccordoServizioParteComune] Errore generatosi durante la creazione di un nuovo accordo di servizio ["+idAccordo+"]: "+e.getMessage(),e);
  2832.         }
  2833.     }
  2834.     
  2835.     /**
  2836.      * Verifica l'esistenza di un accordo registrato.
  2837.      *
  2838.      * @param idAccordo dell'accordo da verificare
  2839.      * @return true se l'accordo esiste, false altrimenti
  2840.      * @throws DriverRegistroServiziException
  2841.      */    
  2842.     @Override
  2843.     public boolean existsAccordoServizioParteComune(IDAccordo idAccordo) throws DriverRegistroServiziException{
  2844.         if( idAccordo == null)
  2845.             return false;
  2846.         if( idAccordo.getNome() == null)
  2847.             return false;
  2848.         
  2849.         try{
  2850.             return this.uddiLib.existsAccordoServizio(idAccordo);
  2851.         }catch(Exception e){
  2852.             this.log.error("[existsAccordoServizioParteComune] Accordo non trovato: "+e.getMessage(),e);
  2853.             return false;
  2854.         }
  2855.     }
  2856.     
  2857.     /**
  2858.      * Aggiorna l'AccordoServizio con i nuovi valori.
  2859.      *  
  2860.      * @param accordoServizio
  2861.      * @throws DriverRegistroServiziException
  2862.      */
  2863.     @Override
  2864.     public void updateAccordoServizioParteComune(AccordoServizioParteComune accordoServizio) throws DriverRegistroServiziException{
  2865.         if( accordoServizio == null)
  2866.             throw new DriverRegistroServiziException("[updateAccordoServizioParteComune] Parametro Non Valido");
  2867.         
  2868.         IDAccordo idAccordoOLD = null;
  2869.         if(accordoServizio.getOldIDAccordoForUpdate()!=null){
  2870.             idAccordoOLD = accordoServizio.getOldIDAccordoForUpdate();
  2871.         }else{
  2872.             idAccordoOLD = this.idAccordoFactory.getIDAccordoFromAccordo(accordoServizio);
  2873.         }

  2875.         try {

  2877.             // Controllo  dell'accordo da Modificare
  2878.             if(idAccordoOLD==null){
  2879.                 throw new DriverRegistroServiziException("Accordo Servizio Parte Comune da modificare non definito");
  2880.             }

  2882.             // controllo inizializzazione UDDI
  2883.             if(this.uddiLib.create == false){
  2884.                 throw new DriverRegistroServiziException("Inizializzazione dell'engine UDDI errata");
  2885.             }

  2887.             // Controllo elementi obbligatori dell'accordo modificato
  2888.             if( (accordoServizio.getNome() == null) ||
  2889.                 (accordoServizio.getProfiloCollaborazione() == null) ){
  2890.                 throw new DriverRegistroServiziException("Accordo Servizio Parte Comune modificato non completamente definito nei parametri obbligatori");
  2891.             }

  2893.             // Controllo pre-esistenza dell'accordo da modificare
  2894.             if( this.uddiLib.existsAccordoServizio(idAccordoOLD) == false){
  2895.                 throw new DriverRegistroServiziException("L'accordo di servizio ["+idAccordoOLD
  2896.                 +"] non risulta gia' inserito nel registro dei servizi.");
  2897.             } 

  2899.             // Controllo non esistenza della nuova identita dell'accordo (se da modificare)
  2900.             IDAccordo idAccordoNEW = this.idAccordoFactory.getIDAccordoFromAccordo(accordoServizio);
  2901.             if(idAccordoOLD.equals(idAccordoNEW) == false){
  2902.                 if( this.uddiLib.existsAccordoServizio(idAccordoNEW) == true){
  2903.                     throw new DriverRegistroServiziException("L'accordo di servizio ["+idAccordoNEW
  2904.                     +"] risulta gia' inserito nel registro dei servizi.");
  2905.                 } 
  2906.             }

  2908.             // Ri-Generazione XML
  2909.             this.generatoreXML.createAccordoServizioParteComune(idAccordoOLD,accordoServizio);
  2910.             
  2911.             // Modifica UDDI
  2912.             if(idAccordoOLD.equals(idAccordoNEW) == false){
  2913.                 String urlXML = this.urlPrefix + CostantiXMLRepository.ACCORDI_DI_SERVIZIO + CostantiRegistroServizi.URL_SEPARATOR + 
  2914.                     this.generatoreXML.mappingIDAccordoToFileName(idAccordoNEW)  + ".xml";
  2915.                 this.uddiLib.updateAccordoServizio(idAccordoOLD,idAccordoNEW,urlXML);
  2916.             }

  2918.         }catch (Exception e) {
  2919.             throw new DriverRegistroServiziException("[updateAccordoServizioParteComune] Errore generatosi durante la modifica dell'accordo di servizio ["+idAccordoOLD+"]: "+e);
  2920.         }
  2921.     }
  2922.     
  2923.     /**
  2924.      * Elimina un AccordoServizio 
  2925.      *  
  2926.      * @param accordoServizio
  2927.      * @throws DriverRegistroServiziException
  2928.      */
  2929.     @Override
  2930.     public void deleteAccordoServizioParteComune(AccordoServizioParteComune accordoServizio) throws DriverRegistroServiziException{
  2931.         if( accordoServizio == null)
  2932.             throw new DriverRegistroServiziException("[deleteAccordoServizioParteComune] Parametro Non Valido");
  2933.                 
  2934.         IDAccordo idAccordo = null;
  2935.         try {
  2936.             idAccordo = this.idAccordoFactory.getIDAccordoFromAccordo(accordoServizio);
  2937.             
  2938.             // controllo inizializzazione UDDI
  2939.             if(this.uddiLib.create == false){
  2940.                 throw new DriverRegistroServiziException("Inizializzazione dell'engine UDDI errata");
  2941.             }
  2942.         
  2943.             // Controllo id dell'accordo da eliminare
  2944.             if(accordoServizio.getNome()==null){
  2945.                 throw new DriverRegistroServiziException("Accordo Servizio Parte Comune da eliminare non definito");
  2946.             }

  2948.             // Controllo pre-esistenza dell'accordo da eliminare
  2949.             if( this.uddiLib.existsAccordoServizio(idAccordo) == false){
  2950.                 throw new DriverRegistroServiziException("L'accordo di servizio ["+idAccordo
  2951.                 +"] non risulta gia' inserito nel registro dei servizi.");
  2952.             } 

  2954.             // Delete from Repository
  2955.             this.generatoreXML.deleteAccordoServizioParteComune(idAccordo);
  2956.                 
  2957.             // Delete from UDDI
  2958.             this.uddiLib.deleteAccordoServizio(idAccordo);
  2959.             
  2960.         }catch (Exception e) {
  2961.             throw new DriverRegistroServiziException("[deleteAccordoServizioParteComune] Errore generatosi durante l'eliminazione dell'accordo di servizio ["+this.idAccordoFactory.getUriFromAccordo(accordoServizio)+"]: "+e.getMessage(),e);
  2962.         }
  2963.     }
  2964.     
  2965.     
  2966.     
  2967.     
  2968.     
  2969.     
  2970.     /**
  2971.      * Crea una nuova Porta di Dominio 
  2972.      * 
  2973.      * @param pdd
  2974.      * @throws DriverRegistroServiziException
  2975.      */
  2976.     @Override
  2977.     public void createPortaDominio(PortaDominio pdd) throws DriverRegistroServiziException{
  2978.         if( pdd == null)
  2979.             throw new DriverRegistroServiziException("[createPortaDominio] Parametro Non Valido");
  2980.         
  2981.         try {

  2983.             // controllo inizializzazione UDDI
  2984.             if(this.uddiLib.create == false){
  2985.                 throw new DriverRegistroServiziException("Inizializzazione dell'engine UDDI errata");
  2986.             }

  2988.             // Controllo elementi obbligatori
  2989.             if( (pdd.getNome() == null) ){
  2990.                 throw new DriverRegistroServiziException("Porta di dominio non completamente definita nei parametri obbligatori");
  2991.             }

  2993.             // Controllo pre-esistenza della porta di dominio
  2994.             if( this.uddiLib.existsPortaDominio(pdd.getNome()) == true){
  2995.                 throw new DriverRegistroServiziException("La porta di dominio ["+pdd.getNome()
  2996.                 +"] risulta gia' inserito nel registro dei servizi.");
  2997.             } 

  2999.             // Generazione XML
  3000.             this.generatoreXML.createPortaDominio(pdd.getNome(),pdd);
  3001.                 
  3002.             // Registrazione nel registro UDDI.
  3003.             String urlXML = this.urlPrefix + CostantiXMLRepository.PORTE_DI_DOMINIO + CostantiRegistroServizi.URL_SEPARATOR + pdd.getNome()  + ".xml";
  3004.             this.uddiLib.createPortaDominio(pdd.getNome(),urlXML);

  3006.         }catch (Exception e) {
  3007.             throw new DriverRegistroServiziException("[createPortaDominio] Errore generatosi durante la creazione di una nuova porta di dominio ["+pdd.getNome()+"]: "+e.getMessage(),e);
  3008.         }
  3009.     }
  3010.     
  3011.     /**
  3012.      * Verifica l'esistenza di una Porta di Dominio.
  3013.      *
  3014.      * @param nome della porta di dominio da verificare
  3015.      * @return true se la porta di dominio esiste, false altrimenti
  3016.      * @throws DriverRegistroServiziException
  3017.      */    
  3018.     @Override
  3019.     public boolean existsPortaDominio(String nome) throws DriverRegistroServiziException{
  3020.         if( nome == null)
  3021.             return false;
  3022.         
  3023.         try{
  3024.             return this.uddiLib.existsPortaDominio(nome);
  3025.         }catch(Exception e){
  3026.             this.log.error("[existsPortaDominio] Porta di dominio non trovata: "+e.getMessage(),e);
  3027.             return false;
  3028.         }
  3029.     }
  3030.     
  3031.     /**
  3032.      * Aggiorna la Porta di Dominio con i nuovi valori.
  3033.      *  
  3034.      * @param pdd
  3035.      * @throws DriverRegistroServiziException
  3036.      */
  3037.     @Override
  3038.     public void updatePortaDominio(PortaDominio pdd) throws DriverRegistroServiziException{
  3039.         if( pdd == null)
  3040.             throw new DriverRegistroServiziException("[updatePortaDominio] Parametro Non Valido");
  3041.         
  3042.         String pddOLD = null;
  3043.         //pddOLD = pdd.getOldNomeForUpdate();
  3044.         if(pddOLD==null)
  3045.             pddOLD = pdd.getNome();
  3046.         
  3047.         try {

  3049.             // controllo inizializzazione UDDI
  3050.             if(this.uddiLib.create == false){
  3051.                 throw new DriverRegistroServiziException("Inizializzazione dell'engine UDDI errata");
  3052.             }

  3054.             // Controllo  della porta di dominio da Modificare
  3055.             if(pddOLD==null){
  3056.                 throw new DriverRegistroServiziException("Porta di dominio da modificare non definito");
  3057.             }

  3059.             // Controllo elementi obbligatori della pdd modificato
  3060.             if( (pdd.getNome() == null) ){
  3061.                 throw new DriverRegistroServiziException("Porta di dominio modificata non completamente definita nei parametri obbligatori");
  3062.             }

  3064.             // Controllo pre-esistenza della pdd da modificare
  3065.             if( this.uddiLib.existsPortaDominio(pddOLD) == false){
  3066.                 throw new DriverRegistroServiziException("La porta di dominio ["+pddOLD
  3067.                 +"] non risulta gia' inserita nel registro dei servizi.");
  3068.             } 

  3070.             // Controllo non esistenza della nuova identita della pdd (se da modificare)
  3071.             String pddNEW = pdd.getNome();
  3072.             if(pddOLD.equals(pddNEW) == false){
  3073.                 if( this.uddiLib.existsPortaDominio(pddNEW) == true){
  3074.                     throw new DriverRegistroServiziException("La porta di dominio ["+pddNEW
  3075.                     +"] risulta gia' inserita nel registro dei servizi.");
  3076.                 } 
  3077.             }

  3079.             // Ri-Generazione XML
  3080.             this.generatoreXML.createPortaDominio(pddOLD,pdd);
  3081.             
  3082.             // Modifica UDDI
  3083.             if(pddOLD.equals(pddNEW) == false){
  3084.                 String urlXML = this.urlPrefix + CostantiXMLRepository.PORTE_DI_DOMINIO + CostantiRegistroServizi.URL_SEPARATOR + pddNEW  + ".xml";
  3085.                 this.uddiLib.updatePortaDominio(pddOLD,pddNEW,urlXML);
  3086.             }

  3088.         }catch (Exception e) {
  3089.             throw new DriverRegistroServiziException("[updatePortaDominio] Errore generatosi durante la modifica della porta di dominio ["+pddOLD+"]: "+e);
  3090.         }
  3091.     }
  3092.     
  3093.     /**
  3094.      * Elimina una Porta di Dominio 
  3095.      *  
  3096.      * @param pdd
  3097.      * @throws DriverRegistroServiziException
  3098.      */
  3099.     @Override
  3100.     public void deletePortaDominio(PortaDominio pdd) throws DriverRegistroServiziException{
  3101.         if( pdd == null)
  3102.             throw new DriverRegistroServiziException("[deletePortaDominio] Parametro Non Valido");
  3103.                 
  3104.         try {
  3105.             // controllo inizializzazione UDDI
  3106.             if(this.uddiLib.create == false){
  3107.                 throw new DriverRegistroServiziException("Inizializzazione dell'engine UDDI errata");
  3108.             }
  3109.         
  3110.             // Controllo id dell'accordo da eliminare
  3111.             if(pdd.getNome()==null){
  3112.                 throw new DriverRegistroServiziException("Porta di dominio da eliminare non definito");
  3113.             }

  3115.             // Controllo pre-esistenza della pdd da eliminare
  3116.             if( this.uddiLib.existsPortaDominio(pdd.getNome()) == false){
  3117.                 throw new DriverRegistroServiziException("La porta di dominio ["+pdd.getNome()
  3118.                 +"] non risulta gia' inserita nel registro dei servizi.");
  3119.             } 

  3121.             // Delete from Repository
  3122.             this.generatoreXML.deletePortaDominio(pdd.getNome());
  3123.                 
  3124.             // Delete from UDDI
  3125.             this.uddiLib.deletePortaDominio(pdd.getNome());
  3126.             
  3127.         }catch (Exception e) {
  3128.             throw new DriverRegistroServiziException("[deletePortaDominio] Errore generatosi durante l'eliminazione della porta di dominio ["+pdd.getNome()+"]: "+e.getMessage(),e);
  3129.         }
  3130.     }
  3131.     
  3132.     
  3133.     
  3134.     
  3135.     
  3136.     
  3137.     
  3138.     
  3139.     
  3140.     /**
  3141.      * Crea una nuovo Gruppo
  3142.      * 
  3143.      * @param gruppo
  3144.      * @throws DriverRegistroServiziException
  3145.      */
  3146.     @Override
  3147.     public void createGruppo(Gruppo gruppo) throws DriverRegistroServiziException{
  3148.         if( gruppo == null)
  3149.             throw new DriverRegistroServiziException("[createGruppo] Parametro Non Valido");
  3150.         
  3151.         try {

  3153.             // controllo inizializzazione UDDI
  3154.             if(this.uddiLib.create == false){
  3155.                 throw new DriverRegistroServiziException("Inizializzazione dell'engine UDDI errata");
  3156.             }

  3158.             // Controllo elementi obbligatori
  3159.             if( (gruppo.getNome() == null) ){
  3160.                 throw new DriverRegistroServiziException("Gruppo non completamente definito nei parametri obbligatori");
  3161.             }

  3163.             // Controllo pre-esistenza del gruppo
  3164.             if( this.uddiLib.existsGruppo(gruppo.getNome()) == true){
  3165.                 throw new DriverRegistroServiziException("Il gruppo ["+gruppo.getNome()
  3166.                 +"] risulta gia' inserito nel registro dei servizi.");
  3167.             } 

  3169.             // Generazione XML
  3170.             this.generatoreXML.createGruppo(gruppo.getNome(),gruppo);
  3171.                 
  3172.             // Registrazione nel registro UDDI.
  3173.             String urlXML = this.urlPrefix + CostantiXMLRepository.GRUPPI + CostantiRegistroServizi.URL_SEPARATOR + gruppo.getNome()  + ".xml";
  3174.             this.uddiLib.createGruppo(gruppo.getNome(),urlXML);

  3176.         }catch (Exception e) {
  3177.             throw new DriverRegistroServiziException("[createGruppo] Errore generatosi durante la creazione di un nuovo gruppo ["+gruppo.getNome()+"]: "+e.getMessage(),e);
  3178.         }
  3179.     }
  3180.     
  3181.     /**
  3182.      * Verifica l'esistenza di un Gruppo
  3183.      *
  3184.      * @param idGruppo idGruppo del gruppo da verificare
  3185.      * @return true se il gruppo esiste, false altrimenti
  3186.      * @throws DriverRegistroServiziException
  3187.      */    
  3188.     @Override
  3189.     public boolean existsGruppo(IDGruppo idGruppo) throws DriverRegistroServiziException{
  3190.         if( idGruppo == null || idGruppo.getNome()==null)
  3191.             return false;
  3192.         
  3193.         try{
  3194.             return this.uddiLib.existsGruppo(idGruppo.getNome());
  3195.         }catch(Exception e){
  3196.             this.log.error("[existsGruppo] Gruppo non trovato: "+e.getMessage(),e);
  3197.             return false;
  3198.         }
  3199.     }
  3200.     
  3201.     /**
  3202.      * Aggiorna il Gruppo con i nuovi valori.
  3203.      *  
  3204.      * @param gruppo
  3205.      * @throws DriverRegistroServiziException
  3206.      */
  3207.     @Override
  3208.     public void updateGruppo(Gruppo gruppo) throws DriverRegistroServiziException{
  3209.         if( gruppo == null)
  3210.             throw new DriverRegistroServiziException("[updateGruppo] Parametro Non Valido");
  3211.         
  3212.         IDGruppo idGruppoOLD = null;
  3213.         //idGruppoOLD = gruppo.getOldIDGruppoForUpdate();
  3214.         //if(idGruppoOLD==null)
  3215.         idGruppoOLD = new IDGruppo(gruppo.getNome());
  3216.         
  3217.         try {

  3219.             // controllo inizializzazione UDDI
  3220.             if(this.uddiLib.create == false){
  3221.                 throw new DriverRegistroServiziException("Inizializzazione dell'engine UDDI errata");
  3222.             }

  3224.             // Controllo  del gruppo da Modificare
  3225.             if(idGruppoOLD==null || idGruppoOLD.getNome()==null){
  3226.                 throw new DriverRegistroServiziException("Gruppo da modificare non definito");
  3227.             }

  3229.             // Controllo elementi obbligatori del gruppo modificato
  3230.             if( (gruppo.getNome() == null) ){
  3231.                 throw new DriverRegistroServiziException("Gruppo modificato non completamente definita nei parametri obbligatori");
  3232.             }

  3234.             // Controllo pre-esistenza del gruppo da modificare
  3235.             if( this.uddiLib.existsGruppo(idGruppoOLD.getNome()) == false){
  3236.                 throw new DriverRegistroServiziException("Il Gruppo ["+idGruppoOLD
  3237.                 +"] non risulta gia' inserita nel registro dei servizi.");
  3238.             } 

  3240.             // Controllo non esistenza della nuova identita del gruppo (se da modificare)
  3241.             IDGruppo idGruppoNEW = new IDGruppo(gruppo.getNome());
  3242.             if(idGruppoOLD.equals(idGruppoNEW) == false){
  3243.                 if( this.uddiLib.existsGruppo(idGruppoNEW.getNome()) == true){
  3244.                     throw new DriverRegistroServiziException("Il Gruppo ["+idGruppoNEW
  3245.                     +"] risulta gia' inserita nel registro dei servizi.");
  3246.                 } 
  3247.             }

  3249.             // Ri-Generazione XML
  3250.             this.generatoreXML.createGruppo(idGruppoOLD.getNome(),gruppo);
  3251.             
  3252.             // Modifica UDDI
  3253.             if(idGruppoOLD.equals(idGruppoNEW) == false){
  3254.                 String urlXML = this.urlPrefix + CostantiXMLRepository.GRUPPI + CostantiRegistroServizi.URL_SEPARATOR + idGruppoNEW  + ".xml";
  3255.                 this.uddiLib.updateGruppo(idGruppoOLD.getNome(),idGruppoNEW.getNome(),urlXML);
  3256.             }

  3258.         }catch (Exception e) {
  3259.             throw new DriverRegistroServiziException("[updateGruppo] Errore generatosi durante la modifica del gruppo ["+idGruppoOLD+"]: "+e);
  3260.         }
  3261.     }
  3262.     
  3263.     /**
  3264.      * Elimina un Gruppo
  3265.      *  
  3266.      * @param gruppo
  3267.      * @throws DriverRegistroServiziException
  3268.      */
  3269.     @Override
  3270.     public void deleteGruppo(Gruppo gruppo) throws DriverRegistroServiziException{
  3271.         if( gruppo == null)
  3272.             throw new DriverRegistroServiziException("[deleteGruppo] Parametro Non Valido");
  3273.                 
  3274.         try {
  3275.             // controllo inizializzazione UDDI
  3276.             if(this.uddiLib.create == false){
  3277.                 throw new DriverRegistroServiziException("Inizializzazione dell'engine UDDI errata");
  3278.             }
  3279.         
  3280.             // Controllo id del gruppo
  3281.             if(gruppo.getNome()==null){
  3282.                 throw new DriverRegistroServiziException("Gruppo da eliminare non definito");
  3283.             }

  3285.             // Controllo pre-esistenza del gruppo da eliminare
  3286.             if( this.uddiLib.existsGruppo(gruppo.getNome()) == false){
  3287.                 throw new DriverRegistroServiziException("Il Gruppo ["+gruppo.getNome()
  3288.                 +"] non risulta gia' inserita nel registro dei servizi.");
  3289.             } 

  3291.             // Delete from Repository
  3292.             this.generatoreXML.deleteGruppo(gruppo.getNome());
  3293.                 
  3294.             // Delete from UDDI
  3295.             this.uddiLib.deleteGruppo(gruppo.getNome());
  3296.             
  3297.         }catch (Exception e) {
  3298.             throw new DriverRegistroServiziException("[deleteGruppo] Errore generatosi durante l'eliminazione del gruppo ["+gruppo.getNome()+"]: "+e.getMessage(),e);
  3299.         }
  3300.     }
  3301.     
  3302.     
  3303.     
  3304.     
  3305.     
  3306.     
  3307.     
  3308.     
  3309.     
  3310.     
  3311.     /**
  3312.      * Crea una nuovo Ruolo
  3313.      * 
  3314.      * @param ruolo
  3315.      * @throws DriverRegistroServiziException
  3316.      */
  3317.     @Override
  3318.     public void createRuolo(Ruolo ruolo) throws DriverRegistroServiziException{
  3319.         if( ruolo == null)
  3320.             throw new DriverRegistroServiziException("[createRuolo] Parametro Non Valido");
  3321.         
  3322.         try {

  3324.             // controllo inizializzazione UDDI
  3325.             if(this.uddiLib.create == false){
  3326.                 throw new DriverRegistroServiziException("Inizializzazione dell'engine UDDI errata");
  3327.             }

  3329.             // Controllo elementi obbligatori
  3330.             if( (ruolo.getNome() == null) ){
  3331.                 throw new DriverRegistroServiziException("Ruolo non completamente definito nei parametri obbligatori");
  3332.             }

  3334.             // Controllo pre-esistenza del ruolo
  3335.             if( this.uddiLib.existsRuolo(ruolo.getNome()) == true){
  3336.                 throw new DriverRegistroServiziException("Il ruolo ["+ruolo.getNome()
  3337.                 +"] risulta gia' inserito nel registro dei servizi.");
  3338.             } 

  3340.             // Generazione XML
  3341.             this.generatoreXML.createRuolo(ruolo.getNome(),ruolo);
  3342.                 
  3343.             // Registrazione nel registro UDDI.
  3344.             String urlXML = this.urlPrefix + CostantiXMLRepository.RUOLI + CostantiRegistroServizi.URL_SEPARATOR + ruolo.getNome()  + ".xml";
  3345.             this.uddiLib.createRuolo(ruolo.getNome(),urlXML);

  3347.         }catch (Exception e) {
  3348.             throw new DriverRegistroServiziException("[createRuolo] Errore generatosi durante la creazione di un nuovo ruolo ["+ruolo.getNome()+"]: "+e.getMessage(),e);
  3349.         }
  3350.     }
  3351.     
  3352.     /**
  3353.      * Verifica l'esistenza di un Ruolo
  3354.      *
  3355.      * @param idRuolo idRuolo del ruolo da verificare
  3356.      * @return true se il ruolo esiste, false altrimenti
  3357.      * @throws DriverRegistroServiziException
  3358.      */    
  3359.     @Override
  3360.     public boolean existsRuolo(IDRuolo idRuolo) throws DriverRegistroServiziException{
  3361.         if( idRuolo == null || idRuolo.getNome()==null)
  3362.             return false;
  3363.         
  3364.         try{
  3365.             return this.uddiLib.existsRuolo(idRuolo.getNome());
  3366.         }catch(Exception e){
  3367.             this.log.error("[existsRuolo] Ruolo non trovato: "+e.getMessage(),e);
  3368.             return false;
  3369.         }
  3370.     }
  3371.     
  3372.     /**
  3373.      * Aggiorna il Ruolo con i nuovi valori.
  3374.      *  
  3375.      * @param ruolo
  3376.      * @throws DriverRegistroServiziException
  3377.      */
  3378.     @Override
  3379.     public void updateRuolo(Ruolo ruolo) throws DriverRegistroServiziException{
  3380.         if( ruolo == null)
  3381.             throw new DriverRegistroServiziException("[updateRuolo] Parametro Non Valido");
  3382.         
  3383.         IDRuolo idRuoloOLD = null;
  3384.         //idRuoloOLD = ruolo.getOldIDRuoloForUpdate();
  3385.         //if(idRuoloOLD==null)
  3386.         idRuoloOLD = new IDRuolo(ruolo.getNome());
  3387.         
  3388.         try {

  3390.             // controllo inizializzazione UDDI
  3391.             if(this.uddiLib.create == false){
  3392.                 throw new DriverRegistroServiziException("Inizializzazione dell'engine UDDI errata");
  3393.             }

  3395.             // Controllo  del ruolo da Modificare
  3396.             if(idRuoloOLD==null || idRuoloOLD.getNome()==null){
  3397.                 throw new DriverRegistroServiziException("Ruolo da modificare non definito");
  3398.             }

  3400.             // Controllo elementi obbligatori del ruolo modificato
  3401.             if( (ruolo.getNome() == null) ){
  3402.                 throw new DriverRegistroServiziException("Ruolo modificato non completamente definita nei parametri obbligatori");
  3403.             }

  3405.             // Controllo pre-esistenza del ruolo da modificare
  3406.             if( this.uddiLib.existsRuolo(idRuoloOLD.getNome()) == false){
  3407.                 throw new DriverRegistroServiziException("Il Ruolo ["+idRuoloOLD
  3408.                 +"] non risulta gia' inserita nel registro dei servizi.");
  3409.             } 

  3411.             // Controllo non esistenza della nuova identita del ruolo (se da modificare)
  3412.             IDRuolo idRuoloNEW = new IDRuolo(ruolo.getNome());
  3413.             if(idRuoloOLD.equals(idRuoloNEW) == false){
  3414.                 if( this.uddiLib.existsRuolo(idRuoloNEW.getNome()) == true){
  3415.                     throw new DriverRegistroServiziException("Il Ruolo ["+idRuoloNEW
  3416.                     +"] risulta gia' inserita nel registro dei servizi.");
  3417.                 } 
  3418.             }

  3420.             // Ri-Generazione XML
  3421.             this.generatoreXML.createRuolo(idRuoloOLD.getNome(),ruolo);
  3422.             
  3423.             // Modifica UDDI
  3424.             if(idRuoloOLD.equals(idRuoloNEW) == false){
  3425.                 String urlXML = this.urlPrefix + CostantiXMLRepository.RUOLI + CostantiRegistroServizi.URL_SEPARATOR + idRuoloNEW  + ".xml";
  3426.                 this.uddiLib.updateRuolo(idRuoloOLD.getNome(),idRuoloNEW.getNome(),urlXML);
  3427.             }

  3429.         }catch (Exception e) {
  3430.             throw new DriverRegistroServiziException("[updateRuolo] Errore generatosi durante la modifica del ruolo ["+idRuoloOLD+"]: "+e);
  3431.         }
  3432.     }
  3433.     
  3434.     /**
  3435.      * Elimina un Ruolo
  3436.      *  
  3437.      * @param ruolo
  3438.      * @throws DriverRegistroServiziException
  3439.      */
  3440.     @Override
  3441.     public void deleteRuolo(Ruolo ruolo) throws DriverRegistroServiziException{
  3442.         if( ruolo == null)
  3443.             throw new DriverRegistroServiziException("[deleteRuolo] Parametro Non Valido");
  3444.                 
  3445.         try {
  3446.             // controllo inizializzazione UDDI
  3447.             if(this.uddiLib.create == false){
  3448.                 throw new DriverRegistroServiziException("Inizializzazione dell'engine UDDI errata");
  3449.             }
  3450.         
  3451.             // Controllo id del ruolo
  3452.             if(ruolo.getNome()==null){
  3453.                 throw new DriverRegistroServiziException("Ruolo da eliminare non definito");
  3454.             }

  3456.             // Controllo pre-esistenza del ruolo da eliminare
  3457.             if( this.uddiLib.existsRuolo(ruolo.getNome()) == false){
  3458.                 throw new DriverRegistroServiziException("Il Ruolo ["+ruolo.getNome()
  3459.                 +"] non risulta gia' inserita nel registro dei servizi.");
  3460.             } 

  3462.             // Delete from Repository
  3463.             this.generatoreXML.deleteRuolo(ruolo.getNome());
  3464.                 
  3465.             // Delete from UDDI
  3466.             this.uddiLib.deleteRuolo(ruolo.getNome());
  3467.             
  3468.         }catch (Exception e) {
  3469.             throw new DriverRegistroServiziException("[deleteRuolo] Errore generatosi durante l'eliminazione del ruolo ["+ruolo.getNome()+"]: "+e.getMessage(),e);
  3470.         }
  3471.     }
  3472.     
  3473.     
  3474.     
  3475.     
  3476.     
  3477.     
  3478.     
  3479.     
  3480.     
  3481.     /**
  3482.      * Crea una nuovo Scope
  3483.      * 
  3484.      * @param scope
  3485.      * @throws DriverRegistroServiziException
  3486.      */
  3487.     @Override
  3488.     public void createScope(Scope scope) throws DriverRegistroServiziException{
  3489.         if( scope == null)
  3490.             throw new DriverRegistroServiziException("[createScope] Parametro Non Valido");
  3491.         
  3492.         try {

  3494.             // controllo inizializzazione UDDI
  3495.             if(this.uddiLib.create == false){
  3496.                 throw new DriverRegistroServiziException("Inizializzazione dell'engine UDDI errata");
  3497.             }

  3499.             // Controllo elementi obbligatori
  3500.             if( (scope.getNome() == null) ){
  3501.                 throw new DriverRegistroServiziException("Scope non completamente definito nei parametri obbligatori");
  3502.             }

  3504.             // Controllo pre-esistenza del scope
  3505.             if( this.uddiLib.existsScope(scope.getNome()) == true){
  3506.                 throw new DriverRegistroServiziException("Il scope ["+scope.getNome()
  3507.                 +"] risulta gia' inserito nel registro dei servizi.");
  3508.             } 

  3510.             // Generazione XML
  3511.             this.generatoreXML.createScope(scope.getNome(),scope);
  3512.                 
  3513.             // Registrazione nel registro UDDI.
  3514.             String urlXML = this.urlPrefix + CostantiXMLRepository.RUOLI + CostantiRegistroServizi.URL_SEPARATOR + scope.getNome()  + ".xml";
  3515.             this.uddiLib.createScope(scope.getNome(),urlXML);

  3517.         }catch (Exception e) {
  3518.             throw new DriverRegistroServiziException("[createScope] Errore generatosi durante la creazione di un nuovo scope ["+scope.getNome()+"]: "+e.getMessage(),e);
  3519.         }
  3520.     }
  3521.     
  3522.     /**
  3523.      * Verifica l'esistenza di un Scope
  3524.      *
  3525.      * @param idScope idScope del scope da verificare
  3526.      * @return true se il scope esiste, false altrimenti
  3527.      * @throws DriverRegistroServiziException
  3528.      */    
  3529.     @Override
  3530.     public boolean existsScope(IDScope idScope) throws DriverRegistroServiziException{
  3531.         if( idScope == null || idScope.getNome()==null)
  3532.             return false;
  3533.         
  3534.         try{
  3535.             return this.uddiLib.existsScope(idScope.getNome());
  3536.         }catch(Exception e){
  3537.             this.log.error("[existsScope] Scope non trovato: "+e.getMessage(),e);
  3538.             return false;
  3539.         }
  3540.     }
  3541.     
  3542.     /**
  3543.      * Aggiorna il Scope con i nuovi valori.
  3544.      *  
  3545.      * @param scope
  3546.      * @throws DriverRegistroServiziException
  3547.      */
  3548.     @Override
  3549.     public void updateScope(Scope scope) throws DriverRegistroServiziException{
  3550.         if( scope == null)
  3551.             throw new DriverRegistroServiziException("[updateScope] Parametro Non Valido");
  3552.         
  3553.         IDScope idScopeOLD = null;
  3554.         //idScopeOLD = scope.getOldIDScopeForUpdate();
  3555.         //if(idScopeOLD==null)
  3556.         idScopeOLD = new IDScope(scope.getNome());
  3557.         
  3558.         try {

  3560.             // controllo inizializzazione UDDI
  3561.             if(this.uddiLib.create == false){
  3562.                 throw new DriverRegistroServiziException("Inizializzazione dell'engine UDDI errata");
  3563.             }

  3565.             // Controllo  del scope da Modificare
  3566.             if(idScopeOLD==null || idScopeOLD.getNome()==null){
  3567.                 throw new DriverRegistroServiziException("Scope da modificare non definito");
  3568.             }

  3570.             // Controllo elementi obbligatori del scope modificato
  3571.             if( (scope.getNome() == null) ){
  3572.                 throw new DriverRegistroServiziException("Scope modificato non completamente definita nei parametri obbligatori");
  3573.             }

  3575.             // Controllo pre-esistenza del scope da modificare
  3576.             if( this.uddiLib.existsScope(idScopeOLD.getNome()) == false){
  3577.                 throw new DriverRegistroServiziException("Il Scope ["+idScopeOLD
  3578.                 +"] non risulta gia' inserita nel registro dei servizi.");
  3579.             } 

  3581.             // Controllo non esistenza della nuova identita del scope (se da modificare)
  3582.             IDScope idScopeNEW = new IDScope(scope.getNome());
  3583.             if(idScopeOLD.equals(idScopeNEW) == false){
  3584.                 if( this.uddiLib.existsScope(idScopeNEW.getNome()) == true){
  3585.                     throw new DriverRegistroServiziException("Il Scope ["+idScopeNEW
  3586.                     +"] risulta gia' inserita nel registro dei servizi.");
  3587.                 } 
  3588.             }

  3590.             // Ri-Generazione XML
  3591.             this.generatoreXML.createScope(idScopeOLD.getNome(),scope);
  3592.             
  3593.             // Modifica UDDI
  3594.             if(idScopeOLD.equals(idScopeNEW) == false){
  3595.                 String urlXML = this.urlPrefix + CostantiXMLRepository.RUOLI + CostantiRegistroServizi.URL_SEPARATOR + idScopeNEW  + ".xml";
  3596.                 this.uddiLib.updateScope(idScopeOLD.getNome(),idScopeNEW.getNome(),urlXML);
  3597.             }

  3599.         }catch (Exception e) {
  3600.             throw new DriverRegistroServiziException("[updateScope] Errore generatosi durante la modifica del scope ["+idScopeOLD+"]: "+e);
  3601.         }
  3602.     }
  3603.     
  3604.     /**
  3605.      * Elimina un Scope
  3606.      *  
  3607.      * @param scope
  3608.      * @throws DriverRegistroServiziException
  3609.      */
  3610.     @Override
  3611.     public void deleteScope(Scope scope) throws DriverRegistroServiziException{
  3612.         if( scope == null)
  3613.             throw new DriverRegistroServiziException("[deleteScope] Parametro Non Valido");
  3614.                 
  3615.         try {
  3616.             // controllo inizializzazione UDDI
  3617.             if(this.uddiLib.create == false){
  3618.                 throw new DriverRegistroServiziException("Inizializzazione dell'engine UDDI errata");
  3619.             }
  3620.         
  3621.             // Controllo id del scope
  3622.             if(scope.getNome()==null){
  3623.                 throw new DriverRegistroServiziException("Scope da eliminare non definito");
  3624.             }

  3626.             // Controllo pre-esistenza del scope da eliminare
  3627.             if( this.uddiLib.existsScope(scope.getNome()) == false){
  3628.                 throw new DriverRegistroServiziException("Il Scope ["+scope.getNome()
  3629.                 +"] non risulta gia' inserita nel registro dei servizi.");
  3630.             } 

  3632.             // Delete from Repository
  3633.             this.generatoreXML.deleteScope(scope.getNome());
  3634.                 
  3635.             // Delete from UDDI
  3636.             this.uddiLib.deleteScope(scope.getNome());
  3637.             
  3638.         }catch (Exception e) {
  3639.             throw new DriverRegistroServiziException("[deleteScope] Errore generatosi durante l'eliminazione del scope ["+scope.getNome()+"]: "+e.getMessage(),e);
  3640.         }
  3641.     }
  3642.     
  3643.     
  3644.     
  3645.     
  3646.     
  3647.     
  3648.     
  3649.     /**
  3650.      * Crea un nuovo Soggetto
  3651.      * 
  3652.      * @param soggetto
  3653.      * @throws DriverRegistroServiziException
  3654.      */
  3655.     @Override
  3656.     public void createSoggetto(Soggetto soggetto) throws DriverRegistroServiziException{
  3657.         if( soggetto == null)
  3658.             throw new DriverRegistroServiziException("[createSoggetto] Parametro Non Valido");
  3659.         
  3660.         try {

  3662.             // controllo inizializzazione UDDI
  3663.             if(this.uddiLib.create == false){
  3664.                 throw new DriverRegistroServiziException("Inizializzazione dell'engine UDDI errata");
  3665.             }
  3666.             
  3667.             // Controllo elementi obbligatori
  3668.             if( (soggetto.getNome() == null) || 
  3669.                     (soggetto.getTipo() == null) ){
  3670.                 throw new DriverRegistroServiziException("Soggetto non definito");
  3671.             }
  3672.             if(soggetto.getConnettore() !=null && !CostantiRegistroServizi.DISABILITATO.equals(soggetto.getConnettore().getTipo())){
  3673.                 boolean connettoreNonDefinito = false;
  3674.                 if( soggetto.getConnettore().getTipo() == null ){
  3675.                     connettoreNonDefinito = true;
  3676.                 }
  3677.                 if(connettoreNonDefinito){
  3678.                     throw new DriverRegistroServiziException("Definizione del punto di accesso del dominio del soggetto non corretta");
  3679.                 }
  3680.             }

  3682.             //  Definizione dati opzionali
  3683.             if( (soggetto.getIdentificativoPorta() == null) || ("".equals(soggetto.getIdentificativoPorta())) ){
  3684.                 soggetto.setIdentificativoPorta(soggetto.getNome() + "SPCoopIT");
  3685.             }
  3686.             if( (soggetto.getDescrizione() == null) ||  ("".equals(soggetto.getDescrizione())) ){
  3687.                 soggetto.setDescrizione("Soggetto "+soggetto.getTipo()+"/"+soggetto.getNome());
  3688.             }
  3689.             IDSoggetto idSoggetto = new IDSoggetto(soggetto.getTipo(),soggetto.getNome(),soggetto.getIdentificativoPorta());
  3690. //          if( (soggetto.getCodiceIpa() == null) || ("".equals(soggetto.getCodiceIpa())) ){
  3691. //              // GESTIRE TRAMITE FACTORY?             
  3692. //              //soggetto.setCodiceIpa(SICAtoOpenSPCoopUtilities.buildIDSoggettoSica(idSoggetto,false));
  3693. //          }
  3694.             
  3695.             
  3696.             // Controllo pre-esistenza del soggetto
  3697.             String idSoggetto_string = soggetto.getTipo() + soggetto.getNome();
  3698.             if(this.uddiLib.existsSoggetto(idSoggetto) == true){
  3699.                 throw new DriverRegistroServiziException("Il soggetto ["+idSoggetto_string
  3700.                 +"] risulta gia' inserito nel registro dei servizi.");
  3701.             } 

  3703.             
  3704.             // Generazione XML
  3705.             String urlXML = this.urlPrefix + idSoggetto_string + CostantiRegistroServizi.URL_SEPARATOR  + idSoggetto_string + ".xml";
  3706.             this.generatoreXML.createSoggetto(idSoggetto,soggetto);
  3707.                 
  3708.             // Registrazione nel registro UDDI.
  3709.             this.uddiLib.createSoggetto(idSoggetto, soggetto.getDescrizione(),urlXML);
  3710.                 
  3711.         }catch (Exception e) {
  3712.             throw new DriverRegistroServiziException("[createSoggetto] Errore generatosi durante la creazione del nuovo Soggetto ["+soggetto.getTipo()+soggetto.getNome()+"]: "+e.getMessage(),e);
  3713.         }
  3714.     }
  3715.     
  3716.     /**
  3717.      * Verifica l'esistenza di un soggetto registrato.
  3718.      *
  3719.      * @param idSoggetto Identificativo del soggetto
  3720.      * @return true se il soggetto esiste, false altrimenti
  3721.      */    
  3722.     @Override
  3723.     public boolean existsSoggetto(IDSoggetto idSoggetto) throws DriverRegistroServiziException{
  3724.         if( idSoggetto == null)
  3725.             return false;
  3726.         try{
  3727.             return this.uddiLib.existsSoggetto(idSoggetto);
  3728.         }catch(Exception e) {
  3729.             return false;
  3730.         }
  3731.     }
  3732.     
  3733.     /**
  3734.      * Aggiorna un Soggetto
  3735.      * 
  3736.      * @param soggetto
  3737.      * @throws DriverRegistroServiziException
  3738.      */
  3739.     @Override
  3740.     public void updateSoggetto(Soggetto soggetto) throws DriverRegistroServiziException{
  3741.         if( soggetto == null)
  3742.             throw new DriverRegistroServiziException("[updateSoggetto] Parametro Non Valido");
  3743.         
  3744.         String tipoOLD = null;
  3745.         String nomeOLD = null;
  3746.         if(soggetto.getOldIDSoggettoForUpdate()!=null){
  3747.             tipoOLD = soggetto.getOldIDSoggettoForUpdate().getTipo();
  3748.             nomeOLD = soggetto.getOldIDSoggettoForUpdate().getNome();
  3749.         }
  3750.         if(tipoOLD==null||nomeOLD==null){
  3751.             tipoOLD = soggetto.getTipo();
  3752.             nomeOLD = soggetto.getNome();
  3753.         }
  3754.         String idSoggettoOLD_string = tipoOLD + nomeOLD;
  3755.         IDSoggetto idSoggettoOLD = new IDSoggetto(tipoOLD,nomeOLD);
  3756.             
  3757.         try {

  3759.             // controllo inizializzazione UDDI
  3760.             if(this.uddiLib.create == false){
  3761.                 throw new DriverRegistroServiziException("Inizializzazione dell'engine UDDI errata");
  3762.             }
  3763.             
  3764.             // Controllo id del soggetto da Modificare
  3765.             if(tipoOLD==null || nomeOLD==null){
  3766.                 throw new DriverRegistroServiziException("Soggetto da modificare non definito");
  3767.             }

  3769.             // Controllo elementi obbligatori del soggetto modificato
  3770.             if( (soggetto.getNome() == null) || 
  3771.                     (soggetto.getTipo() == null) ){
  3772.                 throw new DriverRegistroServiziException("Soggetto modificato non definito");
  3773.             }
  3774.             if(soggetto.getConnettore() !=null && !CostantiRegistroServizi.DISABILITATO.equals(soggetto.getConnettore().getTipo())){
  3775.                 boolean connettoreNonDefinito = false;
  3776.                 if( soggetto.getConnettore().getTipo() == null ){
  3777.                     connettoreNonDefinito = true;
  3778.                 }
  3779.                 if(connettoreNonDefinito){
  3780.                     throw new DriverRegistroServiziException("Definizione del punto di accesso del dominio del soggetto non corretta");
  3781.                 }
  3782.             }
  3783.             
  3784.             // Definizione dati opzionali 
  3785.             if( (soggetto.getIdentificativoPorta() == null) || ("".equals(soggetto.getIdentificativoPorta())) ){
  3786.                 soggetto.setIdentificativoPorta(soggetto.getNome() + "SPCoopIT");
  3787.             }
  3788.             if( (soggetto.getDescrizione() == null) ||  ("".equals(soggetto.getDescrizione())) ){
  3789.                 soggetto.setDescrizione("Soggetto "+soggetto.getTipo()+"/"+soggetto.getNome());
  3790.             }
  3791.             IDSoggetto idSoggettoNEW = new IDSoggetto(soggetto.getTipo(),soggetto.getNome());
  3792. //          if( (soggetto.getCodiceIpa() == null) || ("".equals(soggetto.getCodiceIpa())) ){
  3793. //              // GESTIRE TRAMITE FACTORY?             
  3794. //              //soggetto.setCodiceIpa(SICAtoOpenSPCoopUtilities.buildIDSoggettoSica(idSoggettoNEW,false));
  3795. //          }

  3797.             // Controllo pre-esistenza del soggetto da modificare
  3798.             if( this.uddiLib.existsSoggetto(idSoggettoOLD) == false){
  3799.                 throw new DriverRegistroServiziException("Il soggetto ["+idSoggettoOLD_string
  3800.                 +"] non risulta gia' inserito nel registro dei servizi.");
  3801.             } 

  3803.             // Controllo non esistenza della nuova identita del soggetto (se da modificare)
  3804.             String idSoggettoNEW_string = soggetto.getTipo() + soggetto.getNome();
  3805.             if(idSoggettoOLD_string.equals(idSoggettoNEW_string) == false){
  3806.                 if( this.uddiLib.existsSoggetto(idSoggettoNEW) == true){
  3807.                     throw new DriverRegistroServiziException("La nuova identita da associare al soggetto ["+idSoggettoNEW_string
  3808.                     +"] risulta gia' utilizzata nel registro dei servizi.");
  3809.                 } 
  3810.             }

  3812.             // Ri-Generazione XML
  3813.             String urlXML = this.urlPrefix + idSoggettoNEW_string + CostantiRegistroServizi.URL_SEPARATOR + idSoggettoNEW_string + ".xml";
  3814.             this.generatoreXML.createSoggetto(idSoggettoOLD,soggetto);
  3815.             
  3816.             // Modifica UDDI
  3817.             
  3818.             // Refresh dominio
  3819.             this.uddiLib.updateIdentificativoPortaSoggetto(idSoggettoOLD,soggetto.getIdentificativoPorta());
  3820.             
  3821.             // Refresh descrizione
  3822.             this.uddiLib.updateDescrizioneSoggetto(idSoggettoOLD,soggetto.getDescrizione());
  3823.             
  3824.             if(idSoggettoOLD_string.equals(idSoggettoNEW_string) == false){
  3825.                 // Modifica url che punta al file XML
  3826.                 this.uddiLib.updateUrlXmlSoggetto(idSoggettoOLD,urlXML);

  3828.                 // Modifica nome BusinessService (Per ultima per permettere il Rollback!!!!!)
  3829.                 this.uddiLib.updateIdSoggetto(idSoggettoOLD,idSoggettoNEW);
  3830.             }

  3832.         }catch (Exception e) {
  3833.             throw new DriverRegistroServiziException("[updateSoggetto] Errore generatosi durante la modifica del Soggetto ["+idSoggettoOLD+"]: "+e.getMessage(),e);
  3834.         }
  3835.     }
  3836.     
  3837.     /**
  3838.      * Cancella un Soggetto
  3839.      * 
  3840.      * @param soggetto
  3841.      * @throws DriverRegistroServiziException
  3842.      */
  3843.     @Override
  3844.     public void deleteSoggetto(Soggetto soggetto) throws DriverRegistroServiziException{
  3845.         if( soggetto == null)
  3846.             throw new DriverRegistroServiziException("[deleteSoggetto] Parametro Non Valido");

  3848.         try {
  3849.             //  controllo inizializzazione UDDI
  3850.             if(this.uddiLib.create == false){
  3851.                 throw new DriverRegistroServiziException("Inizializzazione dell'engine UDDI errata");
  3852.             }
  3853.             
  3854.             // Controllo id del soggetto da eliminare
  3855.             if(soggetto.getTipo()==null || soggetto.getNome()==null){
  3856.                 throw new DriverRegistroServiziException("Soggetto da eliminare non definito");
  3857.             }

  3859.             // Controllo pre-esistenza del soggetto da modificare
  3860.             IDSoggetto idSoggetto = new IDSoggetto(soggetto.getTipo(),soggetto.getNome(),soggetto.getIdentificativoPorta());
  3861.             if( this.uddiLib.existsSoggetto(idSoggetto) == false){
  3862.                 throw new DriverRegistroServiziException("Il soggetto ["+idSoggetto
  3863.                 +"] non risulta gia' inserito nel registro dei servizi.");
  3864.             } 

  3866.             // Delete from Repository
  3867.             this.generatoreXML.deleteSoggetto(idSoggetto);
  3868.                 
  3869.             // Delete from UDDI
  3870.             this.uddiLib.deleteSoggetto(idSoggetto);
  3871.             
  3872.         }catch (Exception e) {
  3873.             throw new DriverRegistroServiziException("[deleteSoggetto] Errore generatosi durante l'eliminazione del Soggetto ["+soggetto.getTipo()+soggetto.getNome()+"]: "+e.getMessage(),e);
  3874.         }
  3875.     }
  3876.     
  3877.     
  3878.     
  3879.     
  3880.     
  3881.     
  3882.     
  3883.     /**
  3884.      * Crea un Accordo Servizio Parte Specifica
  3885.      * 
  3886.      * @param asps
  3887.      * @throws DriverRegistroServiziException
  3888.      */
  3889.     @Override
  3890.     public void createAccordoServizioParteSpecifica(AccordoServizioParteSpecifica asps) throws DriverRegistroServiziException{
  3891.     
  3892.         if( asps == null)
  3893.             throw new DriverRegistroServiziException("[createAccordoServizioParteSpecifica] Parametro Non Valido");
  3894.         
  3895.         
  3896.     
  3897.         try {

  3899.             // controllo inizializzazione UDDI
  3900.             if(this.uddiLib.create == false){
  3901.                 throw new DriverRegistroServiziException("Inizializzazione dell'engine UDDI errata");
  3902.             }

  3904.             // Controllo elementi obbligatori
  3905.             if( (asps.getNomeSoggettoErogatore() == null) || 
  3906.                     (asps.getTipoSoggettoErogatore() == null) ){
  3907.                 throw new DriverRegistroServiziException("Soggetto, erogatore del servizio, non definito");
  3908.             }
  3909.             if( (asps.getNome() == null) || 
  3910.                     (asps.getTipo() == null)  || 
  3911.                     (asps.getVersione() == null)  ){
  3912.                 throw new DriverRegistroServiziException("Servizio, non definito");
  3913.             }
  3914.             if(asps.getAccordoServizioParteComune()==null){
  3915.                 throw new DriverRegistroServiziException("Accordo di Servizio, da associare al servizio, non definito");
  3916.             }
  3917.             if(asps.getConfigurazioneServizio()!=null && asps.getConfigurazioneServizio().getConnettore() !=null && 
  3918.                     !CostantiRegistroServizi.DISABILITATO.equals(asps.getConfigurazioneServizio().getConnettore().getTipo())){
  3919.                 boolean connettoreNonDefinito = false;
  3920.                 if( asps.getConfigurazioneServizio().getConnettore().getTipo() == null ){
  3921.                     connettoreNonDefinito = true;
  3922.                 }
  3923.                 if(connettoreNonDefinito){
  3924.                     throw new DriverRegistroServiziException("Definizione del punto di accesso del dominio del servizio non corretta");
  3925.                 }
  3926.             }
  3927.             for(int i=0;i<asps.sizeFruitoreList();i++){
  3928.                 Fruitore checkFr = asps.getFruitore(i);
  3929.                 if( (checkFr.getNome()==null) || (checkFr.getTipo()==null)){
  3930.                     throw new DriverRegistroServiziException("Definizione di un fruitore senza nome o tipo");
  3931.                 }
  3932.                 for(int j=0;j<checkFr.sizeConfigurazioneAzioneList();j++){
  3933.                     ConfigurazioneServizioAzione checkAz = checkFr.getConfigurazioneAzione(j);
  3934.                     if( (checkAz.sizeAzioneList()<=0) || (checkAz.getConnettore()==null)){
  3935.                         throw new DriverRegistroServiziException("Definizione di un azione (fruizione) senza nome o connettore");
  3936.                     }
  3937.                     // controllo connettore
  3938.                     if(checkAz.getConnettore() !=null && !CostantiRegistroServizi.DISABILITATO.equals(checkAz.getConnettore().getTipo())){
  3939.                         boolean connettoreNonDefinito = false;
  3940.                         if( checkAz.getConnettore().getTipo() == null ){
  3941.                             connettoreNonDefinito = true;
  3942.                         }
  3943.                         if(connettoreNonDefinito){
  3944.                             throw new DriverRegistroServiziException("Definizione del punto di accesso delle azioni "+checkAz.getAzioneList()+" della fruizione di servizio non corretta");
  3945.                         }
  3946.                     }
  3947.                 }
  3948.                 // Controllo pre-esistenza del soggetto fruitore
  3949.                 String idSoggettoFruitore_string = checkFr.getTipo() + checkFr.getNome();
  3950.                 IDSoggetto idSoggettoFruitore = new IDSoggetto(checkFr.getTipo(),checkFr.getNome());
  3951.                 if( this.uddiLib.existsSoggetto(idSoggettoFruitore) == false){
  3952.                     throw new DriverRegistroServiziException("Il fruitore ["+idSoggettoFruitore_string
  3953.                     +"] non risulta gia' inserito nel registro dei servizi.");
  3954.                 } 
  3955.             }
  3956.             if(asps.getConfigurazioneServizio()!=null){
  3957.                 for(int i=0;i<asps.getConfigurazioneServizio().sizeConfigurazioneAzioneList();i++){
  3958.                     ConfigurazioneServizioAzione checkAz = asps.getConfigurazioneServizio().getConfigurazioneAzione(i);
  3959.                     if( (checkAz.sizeAzioneList()<=0) || (checkAz.getConnettore()==null)){
  3960.                         throw new DriverRegistroServiziException("Definizione di un azione senza nome o connettore");
  3961.                     }
  3962.                     // controllo connettore
  3963.                     if(checkAz.getConnettore() !=null && !CostantiRegistroServizi.DISABILITATO.equals(checkAz.getConnettore().getTipo())){
  3964.                         boolean connettoreNonDefinito = false;
  3965.                         if( checkAz.getConnettore().getTipo() == null ){
  3966.                             connettoreNonDefinito = true;
  3967.                         }
  3968.                         if(connettoreNonDefinito){
  3969.                             throw new DriverRegistroServiziException("Definizione del punto di accesso delle azioni "+checkAz.getAzioneList()+" del servizio non corretta");
  3970.                         }
  3971.                     }
  3972.                 }
  3973.             }

  3975.             // Controllo pre-esistenza del soggetto erogatore
  3976.             IDSoggetto idSoggettoErogatore = new IDSoggetto(asps.getTipoSoggettoErogatore(),asps.getNomeSoggettoErogatore());
  3977.             String idSoggettoErogatore_string = asps.getTipoSoggettoErogatore()+asps.getNomeSoggettoErogatore();
  3978.             if( this.uddiLib.existsSoggetto(idSoggettoErogatore) == false){
  3979.                 throw new DriverRegistroServiziException("Il soggetto ["+idSoggettoErogatore_string
  3980.                 +"] non risulta gia' inserito nel registro dei servizi.");
  3981.             } 

  3983.             // Controllo pre-esistenza del servizio
  3984.             String idServizio_string = asps.getTipo() + asps.getNome() + asps.getVersione();
  3985.             String uriServizio = this.idServizioFactory.getUriFromAccordo(asps);
  3986.             IDServizio idServizio = this.idServizioFactory.getIDServizioFromAccordo(asps);
  3987.             if (this.uddiLib.existsServizio(idServizio)==true){
  3988.                 throw new DriverRegistroServiziException("Il servizio ["+uriServizio+"] risulta gia' registrato nel registro");
  3989.             }

  3991.             String urlXML = this.urlPrefix + idSoggettoErogatore_string + CostantiRegistroServizi.URL_SEPARATOR +CostantiXMLRepository.SERVIZI+ 
  3992.                 CostantiRegistroServizi.URL_SEPARATOR + idServizio_string  + ".xml";

  3994.             // Generazione XML
  3995.             this.generatoreXML.createAccordoServizioParteSpecifica(idServizio,asps);
  3996.             
  3997.             // Registrazione nel registro UDDI.
  3998.             this.uddiLib.createServizio(idServizio,
  3999.                     urlXML,this.idAccordoFactory.getIDAccordoFromUri(asps.getAccordoServizioParteComune()));
  4000.                 
  4001.         }catch (Exception e) {
  4002.             throw new DriverRegistroServiziException("[createAccordoServizioParteSpecifica] Errore generatosi durante la creazione del nuovo Servizio ["+
  4003.                     this.idServizioFactory.getUriFromAccordo(asps)+"]: "+e.getMessage(),e);
  4004.         }
  4005.     }       
  4006.     
  4007.     /**
  4008.      * Verifica l'esistenza di un servizio registrato.
  4009.      *
  4010.      * @param idServizio Identificativo del servizio
  4011.      * @return true se il servizio esiste, false altrimenti
  4012.      */    
  4013.     @Override
  4014.     public boolean existsAccordoServizioParteSpecifica(IDServizio idServizio) throws DriverRegistroServiziException{
  4015.         if( idServizio == null)
  4016.             return false;
  4017.     
  4018.         try{
  4019.             this.getAccordoServizioParteSpecifica(idServizio);
  4020.             
  4021.             return true;
  4022.         }catch(DriverRegistroServiziNotFound de){
  4023.             return false;
  4024.         }
  4025.         catch(Exception e){
  4026.             this.log.error("[existsAccordoServizioParteSpecifica] Servizio non trovato: "+e.getMessage(),e);
  4027.             return false;
  4028.         }
  4029.     }
  4030.     
  4031.     
  4032.     /**
  4033.      * Aggiorna un Accordo Servizio Parte Specifica
  4034.      * 
  4035.      * @param asps
  4036.      * @throws DriverRegistroServiziException
  4037.      */
  4038.     @Override
  4039.     public void updateAccordoServizioParteSpecifica(AccordoServizioParteSpecifica asps) throws DriverRegistroServiziException{
  4040.         
  4041.         if( asps == null)
  4042.             throw new DriverRegistroServiziException("[updateAccordoServizioParteSpecifica] Parametro Non Valido");
  4043.         
  4044.     
  4045.         String tipoServizioOLD = null;
  4046.         String nomeServizioOLD = null;
  4047.         Integer versioneServizioOLD = null;
  4048.         if(asps.getOldIDServizioForUpdate()!=null){
  4049.             tipoServizioOLD = asps.getOldIDServizioForUpdate().getTipo();
  4050.             nomeServizioOLD = asps.getOldIDServizioForUpdate().getNome();
  4051.             versioneServizioOLD = asps.getOldIDServizioForUpdate().getVersione();
  4052.         }
  4053.         if(tipoServizioOLD==null||nomeServizioOLD==null||versioneServizioOLD==null){
  4054.             tipoServizioOLD = asps.getTipo();
  4055.             nomeServizioOLD = asps.getNome();
  4056.             versioneServizioOLD = asps.getVersione();
  4057.         }
  4058.         String tipoSoggettoOLD = null;
  4059.         String nomeSoggettoOLD = null;
  4060.         if(asps.getOldIDServizioForUpdate()!=null && asps.getOldIDServizioForUpdate().getSoggettoErogatore()!=null){
  4061.             tipoSoggettoOLD = asps.getOldIDServizioForUpdate().getSoggettoErogatore().getTipo();
  4062.             nomeSoggettoOLD = asps.getOldIDServizioForUpdate().getSoggettoErogatore().getNome();
  4063.         }
  4064.         if(tipoSoggettoOLD==null||nomeSoggettoOLD==null){
  4065.             tipoSoggettoOLD = asps.getTipoSoggettoErogatore();
  4066.             nomeSoggettoOLD = asps.getNomeSoggettoErogatore();
  4067.         }
  4068.         String idSoggettoOLD_string = tipoSoggettoOLD+nomeSoggettoOLD;
  4069.         IDSoggetto idSoggettoOLD = new IDSoggetto(tipoSoggettoOLD,nomeSoggettoOLD);
  4070.         String idServizioOLD_string = tipoServizioOLD + nomeServizioOLD+versioneServizioOLD;
  4071.         IDServizio idServizioOLD = this.idServizioFactory.getIDServizioFromValues(tipoServizioOLD,nomeServizioOLD, idSoggettoOLD, versioneServizioOLD);
  4072.                 
  4073.         try {

  4075.             // controllo inizializzazione UDDI
  4076.             if(this.uddiLib.create == false){
  4077.                 throw new DriverRegistroServiziException("Inizializzazione dell'engine UDDI errata");
  4078.             }
  4079.             
  4080.             // Controllo elementi obbligatori
  4081.             // vecchio ID Soggetto
  4082.             if( (tipoSoggettoOLD == null) || 
  4083.                     (nomeSoggettoOLD == null) ){
  4084.                 throw new DriverRegistroServiziException("Soggetto da modificare, erogatore del servizio, non definito");
  4085.             }
  4086.             // nuovo ID Soggetto
  4087.             if( (asps.getTipoSoggettoErogatore() == null) || 
  4088.                     (asps.getNomeSoggettoErogatore() == null) ){
  4089.                 throw new DriverRegistroServiziException("Soggetto, erogatore del servizio, non definito");
  4090.             }
  4091.             // vecchio ID Servizio
  4092.             if( (tipoServizioOLD == null) || 
  4093.                     (nomeServizioOLD == null) ){
  4094.                 throw new DriverRegistroServiziException("Servizio da modificare non definito");
  4095.             }
  4096.             // nuovo ID Servizio
  4097.             if( (asps.getNome() == null) || 
  4098.                     (asps.getTipo() == null) || 
  4099.                     (asps.getVersione() == null) ){
  4100.                 throw new DriverRegistroServiziException("Dati del nuovo servizio, non definiti");
  4101.             }
  4102.             // accordo
  4103.             if(asps.getAccordoServizioParteComune()==null){
  4104.                 throw new DriverRegistroServiziException("Accordo di Servizio, da associare al servizio, non definito");
  4105.             }
  4106.             // connettore
  4107.             if(asps.getConfigurazioneServizio()!=null && asps.getConfigurazioneServizio().getConnettore() !=null && 
  4108.                     !CostantiRegistroServizi.DISABILITATO.equals(asps.getConfigurazioneServizio().getConnettore().getTipo())){
  4109.                 boolean connettoreNonDefinito = false;
  4110.                 if( asps.getConfigurazioneServizio().getConnettore().getTipo() == null ){
  4111.                     connettoreNonDefinito = true;
  4112.                 }
  4113.                 if(connettoreNonDefinito){
  4114.                     throw new DriverRegistroServiziException("Definizione del punto di accesso del dominio del servizio non corretta");
  4115.                 }
  4116.             }
  4117.             // fruitori
  4118.             for(int i=0;i<asps.sizeFruitoreList();i++){
  4119.                 Fruitore checkFr = asps.getFruitore(i);
  4120.                 if( (checkFr.getNome()==null) || (checkFr.getTipo()==null)){
  4121.                     throw new DriverRegistroServiziException("Definizione di un fruitore senza nome o tipo");
  4122.                 }
  4123.                 for(int j=0;j<checkFr.sizeConfigurazioneAzioneList();j++){
  4124.                     ConfigurazioneServizioAzione checkAz = checkFr.getConfigurazioneAzione(j);
  4125.                     if( (checkAz.sizeAzioneList()<=0) || (checkAz.getConnettore()==null)){
  4126.                         throw new DriverRegistroServiziException("Definizione di un fruitore senza nome o connettore");
  4127.                     }
  4128.                     // controllo connettore
  4129.                     if(checkAz.getConnettore() !=null && !CostantiRegistroServizi.DISABILITATO.equals(checkAz.getConnettore().getTipo())){
  4130.                         boolean connettoreNonDefinito = false;
  4131.                         if( checkAz.getConnettore().getTipo() == null ){
  4132.                             connettoreNonDefinito = true;
  4133.                         }
  4134.                         if(connettoreNonDefinito){
  4135.                             throw new DriverRegistroServiziException("Definizione del punto di accesso dell'azione "+checkAz.getAzioneList()+" della fruizione di servizio non corretta");
  4136.                         }
  4137.                     }
  4138.                 }
  4139.                 // Controllo pre-esistenza del soggetto fruitore
  4140.                 /*String idSoggettoFruitore_string = checkFr.getTipo() + checkFr.getNome();
  4141.                 IDSoggetto idSoggettoFruitore = new IDSoggetto(checkFr.getTipo(),checkFr.getNome());
  4142.                 if( this.uddiLib.existsSoggetto(idSoggettoFruitore) == false){
  4143.                     throw new DriverRegistroServiziException("Il fruitore ["+idSoggettoFruitore_string
  4144.                     +"] non risulta gia' inserito nel registro dei servizi.");
  4145.                 } */
  4146.             }
  4147.             // azioni-fruitori-connettori
  4148.             if(asps.getConfigurazioneServizio()!=null){
  4149.                 for(int i=0;i<asps.getConfigurazioneServizio().sizeConfigurazioneAzioneList();i++){
  4150.                     ConfigurazioneServizioAzione checkAz = asps.getConfigurazioneServizio().getConfigurazioneAzione(i);
  4151.                     if( (checkAz.sizeAzioneList()<=0) || (checkAz.getConnettore()==null)){
  4152.                         throw new DriverRegistroServiziException("Definizione di un fruitore senza nome o connettore");
  4153.                     }
  4154.                     // controllo connettore
  4155.                     if(checkAz.getConnettore() !=null && !CostantiRegistroServizi.DISABILITATO.equals(checkAz.getConnettore().getTipo())){
  4156.                         boolean connettoreNonDefinito = false;
  4157.                         if( checkAz.getConnettore().getTipo() == null ){
  4158.                             connettoreNonDefinito = true;
  4159.                         }
  4160.                         if(connettoreNonDefinito){
  4161.                             throw new DriverRegistroServiziException("Definizione del punto di accesso dell'azione "+checkAz.getAzioneList()+" del servizio non corretta");
  4162.                         }
  4163.                     }
  4164.                 }
  4165.             }
  4166.             
  4167.         

  4169.             // Controllo pre-esistenza del soggetto erogatore da modificare
  4170.             if( this.uddiLib.existsSoggetto(idSoggettoOLD) == false){
  4171.                 throw new DriverRegistroServiziException("Il soggetto ["+idSoggettoOLD_string
  4172.                 +"] da modificare, non risulta gia' inserito nel registro dei servizi.");
  4173.             } 

  4175.     
  4176.             
  4177.             // Controllo pre-esistenza del nuovo soggetto erogatore
  4178.             String idSoggettoNEW_string = asps.getTipoSoggettoErogatore() + asps.getNomeSoggettoErogatore();
  4179.             IDSoggetto idSoggettoNEW = new IDSoggetto(asps.getTipoSoggettoErogatore(),asps.getNomeSoggettoErogatore());
  4180.             if( idSoggettoOLD_string.equals(idSoggettoNEW_string) == false ){
  4181.                 if( this.uddiLib.existsSoggetto(idSoggettoNEW) == false){
  4182.                     throw new DriverRegistroServiziException("Il soggetto ["+idSoggettoNEW_string
  4183.                     +"] a cui re-assegnare il servizio, non risulta gia' inserito nel registro dei servizi.");
  4184.                 } 
  4185.             }
  4186.             
  4187.                 
  4188.             
  4189.             // Controllo pre-esistenza del servizio da modificare
  4190.             if (this.uddiLib.existsServizio(idServizioOLD)==false){
  4191.                 throw new DriverRegistroServiziException("Il servizio ["+idServizioOLD_string+"] erogato dal soggetto ["+idSoggettoOLD_string+"] non risulta gia' registrato nel registro");
  4192.             }
  4193.     
  4194.             // check esistenza nuovo servizio
  4195.             IDServizio idServizioNEW = this.idServizioFactory.getIDServizioFromValues(asps.getTipo(),asps.getNome(), idSoggettoNEW, asps.getVersione());
  4196.             String idServizioNEW_string = asps.getTipo() + asps.getNome() + asps.getVersione();
  4197.             if(idServizioOLD_string.equals(idServizioNEW_string) == false){
  4198.                 // Controllo non esistenza del servizio da creare
  4199.                 if (this.uddiLib.existsServizio(idServizioNEW)==true){
  4200.                     throw new DriverRegistroServiziException("Il servizio ["+idServizioNEW_string+"] erogato dal soggetto ["+idSoggettoNEW_string+"] risulta gia' registrato nel registro");
  4201.                 }
  4202.             }
  4203.                 
  4204.             String urlXML = this.urlPrefix + idSoggettoNEW_string + CostantiRegistroServizi.URL_SEPARATOR +CostantiXMLRepository.SERVIZI+ 
  4205.                 CostantiRegistroServizi.URL_SEPARATOR + idServizioNEW_string  + ".xml";
  4206.         
  4207.             if( idSoggettoOLD_string.equals(idSoggettoNEW_string) == true ){
  4208.                 // NON e' CAMBIATO IL SOGGETTO EROGATORE.
  4209.                 
  4210.                 // Ri-Generazione XML
  4211.                 this.generatoreXML.createAccordoServizioParteSpecifica(idServizioOLD,asps);
  4212.                     
  4213.                 // Modifica UDDI
  4214.                 // refresh AccordoServizio
  4215.                 this.uddiLib.updateAccordoServizio(idServizioOLD,this.idAccordoFactory.getIDAccordoFromUri(asps.getAccordoServizioParteComune()));
  4216.                     
  4217.                 //if(idServizioOLD_string.equals(idServizioNEW_string) == false){
  4218.                 // Lo faccio cmq per non incasinare la govwayConsole
  4219.                 
  4220.                 // refresh url XML
  4221.                 this.uddiLib.updateUrlXmlServizio(idServizioOLD,urlXML);
  4222.                     
  4223.                 // Modifica nome BusinessService (Per ultima per permettere il Rollback!!!!!)
  4224.                 this.uddiLib.updateIdServizio(idServizioOLD,idServizioNEW);
  4225.                         
  4226.                 //}
  4227.                     
  4228.                 
  4229.             }else{
  4230.                 // E' CAMBIATO IL SOGGETTO EROGATORE
  4231.                     
  4232.                 // Delete from Repository
  4233.                 this.generatoreXML.deleteAccordoServizioParteSpecifica(idServizioOLD);
  4234.                 
  4235.                 // Delete from UDDI
  4236.                 this.uddiLib.deleteServizio(idServizioOLD);
  4237.                 
  4238.                 // Generazione XML
  4239.                 this.generatoreXML.createAccordoServizioParteSpecifica(idServizioNEW,asps);
  4240.                     
  4241.                 // Registrazione nel registro UDDI.
  4242.                 this.uddiLib.createServizio(idServizioNEW,
  4243.                         urlXML,this.idAccordoFactory.getIDAccordoFromUri(asps.getAccordoServizioParteComune()));
  4244.             }

  4246.         }catch (Exception e) {
  4247.             throw new DriverRegistroServiziException("[updateAccordoServizioParteSpecifica] Errore generatosi durante la modifica del Servizio ["+idServizioOLD_string+"] erogato dal soggetto ["+
  4248.             idSoggettoOLD_string+"]: "+e.getMessage(),e);
  4249.         }
  4250.     }
  4251.     
  4252.     /**
  4253.      * Cancella un Accordo Servizio Parte Specifica
  4254.      * 
  4255.      * @param asps
  4256.      * @throws DriverRegistroServiziException
  4257.      */
  4258.     @Override
  4259.     public void deleteAccordoServizioParteSpecifica(AccordoServizioParteSpecifica asps) throws DriverRegistroServiziException{
  4260.     
  4261.         if( asps == null)
  4262.             throw new DriverRegistroServiziException("[deleteAccordoServizioParteSpecifica] Parametro Non Valido");
  4263.         
  4264.         
  4265.         String idSoggetto_string = asps.getTipoSoggettoErogatore() + asps.getNomeSoggettoErogatore();
  4266.         String idServizio_string = asps.getTipo() + asps.getNome() + asps.getVersione();
  4267.                 
  4268.         try {
  4269.             // Controllo id del soggetto 
  4270.             if(asps.getTipoSoggettoErogatore()==null || asps.getNomeSoggettoErogatore()==null){
  4271.                 throw new DriverRegistroServiziException("Soggetto non definito");
  4272.             }
  4273.             // Controllo id del servizio da eliminare
  4274.             if(asps.getTipo()==null || asps.getNome()==null || asps.getVersione()==null){
  4275.                 throw new DriverRegistroServiziException("Servizio da eliminare non definito");
  4276.             }
  4277.             // Controllo pre-esistenza del soggetto
  4278.             IDSoggetto idSoggetto = new IDSoggetto(asps.getTipoSoggettoErogatore(),asps.getNomeSoggettoErogatore());
  4279.             if( this.uddiLib.existsSoggetto(idSoggetto) == false){
  4280.                 throw new DriverRegistroServiziException("Il soggetto ["+idSoggetto_string
  4281.                 +"] non risulta gia' inserito nel registro dei servizi.");
  4282.             } 
  4283.             // Controllo pre-esistenza del servizio
  4284.             IDServizio idServizio = this.idServizioFactory.getIDServizioFromValues(asps.getTipo(),asps.getNome(), idSoggetto, asps.getVersione());
  4285.             if (this.uddiLib.existsServizio(idServizio)==false){
  4286.                 throw new DriverRegistroServiziException("Il servizio ["+idServizio_string+"] erogato dal soggetto ["+idSoggetto_string+"] non risulta gia' registrato nel registro");
  4287.             }

  4289.             // Delete from Repository
  4290.             this.generatoreXML.deleteAccordoServizioParteSpecifica(idServizio);

  4292.             // Delete from UDDI
  4293.             this.uddiLib.deleteServizio(idServizio);

  4295.         }catch (Exception e) {
  4296.             throw new DriverRegistroServiziException("[deleteAccordoServizioParteSpecifica] Errore generatosi durante l'eliminazione del Servizio ["+idServizio_string
  4297.             +"] erogato dal soggetto ["+idSoggetto_string+"]: "+e.getMessage(),e);
  4298.         }
  4299.     }
  4300.     
  4301.     
  4302.     
  4303.     //RESET
  4304.     @Override
  4305.     public void reset() throws DriverRegistroServiziException{
  4306.         String inEliminazione = null;
  4307.         try{
  4308.             AccordoServizioParteComune[] accordiRegistrati = this.generatoreXML.getAccordiServizioParteComune();
  4309.             if(accordiRegistrati!=null){
  4310.                 for(int i=0; i<accordiRegistrati.length;i++){
  4311.                     IDAccordo idInEliminazione = this.idAccordoFactory.getIDAccordoFromAccordo(accordiRegistrati[i]);
  4312.                     this.log.info("eliminazione accordo di servizio ["+idInEliminazione+"] in corso...");
  4313.                     if(this.existsAccordoServizioParteComune(idInEliminazione)){
  4314.                         this.deleteAccordoServizioParteComune(accordiRegistrati[i]);
  4315.                     }else{
  4316.                         this.generatoreXML.deleteAccordoServizioParteComune(idInEliminazione);
  4317.                     }
  4318.                     this.log.info("eliminazione accordo di servizio ["+idInEliminazione+"] effettuata.");
  4319.                 }
  4320.             }
  4321.         }catch (Exception e) {
  4322.             this.log.info("Errore durante l'eliminazione di ["+inEliminazione+"]: "+e.getMessage(),e);
  4323.             throw new DriverRegistroServiziException("Errore durante la cancellazione degli accordi registrati ["+inEliminazione+"]: "+e.getMessage(),e);
  4324.         }
  4325.         try{
  4326.             AccordoCooperazione[] accordiCooperazioneRegistrati = this.generatoreXML.getAccordiCooperazione();
  4327.             if(accordiCooperazioneRegistrati!=null){
  4328.                 for(int i=0; i<accordiCooperazioneRegistrati.length;i++){
  4329.                     IDAccordoCooperazione idInEliminazione = this.idAccordoCooperazioneFactory.getIDAccordoFromAccordo(accordiCooperazioneRegistrati[i]);
  4330.                     this.log.info("eliminazione accordo di cooperazione ["+idInEliminazione+"] in corso...");
  4331.                     if(this.existsAccordoCooperazione(idInEliminazione)){
  4332.                         this.deleteAccordoCooperazione(accordiCooperazioneRegistrati[i]);
  4333.                     }else{
  4334.                         this.generatoreXML.deleteAccordoCooperazione(idInEliminazione);
  4335.                     }
  4336.                     this.log.info("eliminazione accordo di cooperazione ["+idInEliminazione+"] effettuata.");
  4337.                 }
  4338.             }
  4339.         }catch (Exception e) {
  4340.             this.log.info("Errore durante l'eliminazione di ["+inEliminazione+"]: "+e.getMessage(),e);
  4341.             throw new DriverRegistroServiziException("Errore durante la cancellazione degli accordi registrati ["+inEliminazione+"]: "+e.getMessage(),e);
  4342.         }
  4343.         try{
  4344.             AccordoServizioParteSpecifica[] serviziRegistrati = this.generatoreXML.getAccordiServiziParteSpecifica();
  4345.             if(serviziRegistrati!=null){
  4346.                 for(int i=0; i<serviziRegistrati.length;i++){
  4347.                     inEliminazione=this.idServizioFactory.getUriFromAccordo(serviziRegistrati[i]);
  4348.                     this.log.info("eliminazione servizio ["+inEliminazione+"] in corso...");
  4349.                     IDServizio idS = this.idServizioFactory.getIDServizioFromAccordo(serviziRegistrati[i]);
  4350.                     if(this.existsAccordoServizioParteSpecifica(idS)){
  4351.                         this.deleteAccordoServizioParteSpecifica(serviziRegistrati[i]);
  4352.                     }else{
  4353.                         this.generatoreXML.deleteAccordoServizioParteSpecifica(idS);
  4354.                     }
  4355.                     this.log.info("eliminazione servizio ["+inEliminazione+"] effettuata.");
  4356.                 }
  4357.             }
  4358.         }catch (Exception e) {
  4359.             this.log.info("Errore durante l'eliminazione di ["+inEliminazione+"]: "+e.getMessage(),e);
  4360.             throw new DriverRegistroServiziException("Errore durante la cancellazione dei servizi registrati ["+inEliminazione+"]: "+e.getMessage(),e);
  4361.         }
  4362.         try{
  4363.             Soggetto[] soggettiRegistrati = this.generatoreXML.getSoggetti();
  4364.             if(soggettiRegistrati!=null){
  4365.                 for(int i=0; i<soggettiRegistrati.length;i++){
  4366.                     inEliminazione=soggettiRegistrati[i].getTipo()+"/"+soggettiRegistrati[i].getNome();
  4367.                     this.log.info("eliminazione soggetto ["+inEliminazione+"] in corso...");
  4368.                     IDSoggetto idS = new IDSoggetto(soggettiRegistrati[i].getTipo(),soggettiRegistrati[i].getNome());
  4369.                     if(this.existsSoggetto(idS)) {
  4370.                         this.deleteSoggetto(soggettiRegistrati[i]);
  4371.                     }else{
  4372.                         this.generatoreXML.deleteSoggetto(idS);
  4373.                     }
  4374.                     this.log.info("eliminazione soggetto ["+inEliminazione+"] effettuata.");
  4375.                 }
  4376.             }
  4377.         }catch (Exception e) {
  4378.             this.log.info("Errore durante l'eliminazione di ["+inEliminazione+"]: "+e.getMessage(),e);
  4379.             throw new DriverRegistroServiziException("Errore durante la cancellazione dei soggetti registrati ["+inEliminazione+"]: "+e.getMessage(),e);
  4380.         }
  4381.         try{
  4382.             PortaDominio[] pddRegistrate = this.generatoreXML.getPorteDominio();
  4383.             if(pddRegistrate!=null){
  4384.                 for(int i=0; i<pddRegistrate.length;i++){
  4385.                     inEliminazione = pddRegistrate[i].getNome();
  4386.                     this.log.info("eliminazione porta di dominio ["+inEliminazione+"] in corso...");
  4387.                     if(this.existsPortaDominio(inEliminazione)){
  4388.                         this.deletePortaDominio(pddRegistrate[i]);
  4389.                     }else{
  4390.                         this.generatoreXML.deletePortaDominio(inEliminazione);
  4391.                     }
  4392.                     this.log.info("eliminazione porta di dominio ["+inEliminazione+"] effettuata.");
  4393.                 }
  4394.             }
  4395.         }catch (Exception e) {
  4396.             this.log.info("Errore durante l'eliminazione di ["+inEliminazione+"]: "+e.getMessage(),e);
  4397.             throw new DriverRegistroServiziException("Errore durante la cancellazione delle porte di dominio registrate ["+inEliminazione+"]: "+e.getMessage(),e);
  4398.         }
  4399.     }
  4400.     
  4401.     
  4402.     
  4403.     
  4404.     
  4405.     /**
  4406.      * Metodo che verica la connessione ad una risorsa.
  4407.      * Se la connessione non e' presente, viene lanciata una eccezione che contiene il motivo della mancata connessione
  4408.      * 
  4409.      * @throws DriverException eccezione che contiene il motivo della mancata connessione
  4410.      */
  4411.     @Override
  4412.     public void isAlive() throws CoreException{
  4413.         
  4414.         if(this.create==false)
  4415.             throw new CoreException("Driver non inizializzato");
  4416.         
  4417.         try{
  4418.             if(this.uddiLib.getTModel("isAliveTest",UDDILib.TMODEL_OPENSPCOOP)==null)
  4419.                 throw new Exception("TModel ["+UDDILib.TMODEL_OPENSPCOOP+"] non trovata");
  4420.         }catch(Exception e){
  4421.             throw new CoreException("Connessione al registro non disponibile: "+e.getMessage(),e);
  4422.         }
  4423.     }

  4425. }
Created with JaCoCo 0.8.8.202204050719