DriverRegistroServiziXML.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.xml;

  26. import java.io.File;
  27. import java.io.FileInputStream;
  28. import java.io.InputStream;
  29. import java.net.HttpURLConnection;
  30. import java.net.URL;
  31. import java.net.URLConnection;
  32. import java.util.ArrayList;
  33. import java.util.List;

  35. import org.openspcoop2.core.commons.CoreException;
  36. import org.openspcoop2.core.commons.Filtri;
  37. import org.openspcoop2.core.commons.IMonitoraggioRisorsa;
  38. import org.openspcoop2.core.id.IDAccordo;
  39. import org.openspcoop2.core.id.IDAccordoAzione;
  40. import org.openspcoop2.core.id.IDAccordoCooperazione;
  41. import org.openspcoop2.core.id.IDFruizione;
  42. import org.openspcoop2.core.id.IDGruppo;
  43. import org.openspcoop2.core.id.IDPortType;
  44. import org.openspcoop2.core.id.IDPortTypeAzione;
  45. import org.openspcoop2.core.id.IDResource;
  46. import org.openspcoop2.core.id.IDRuolo;
  47. import org.openspcoop2.core.id.IDScope;
  48. import org.openspcoop2.core.id.IDServizio;
  49. import org.openspcoop2.core.id.IDSoggetto;
  50. import org.openspcoop2.core.registry.AccordoServizioParteComune;
  51. import org.openspcoop2.core.registry.AccordoServizioParteSpecifica;
  52. import org.openspcoop2.core.registry.Azione;
  53. import org.openspcoop2.core.registry.CredenzialiSoggetto;
  54. import org.openspcoop2.core.registry.Documento;
  55. import org.openspcoop2.core.registry.Fruitore;
  56. import org.openspcoop2.core.registry.Gruppo;
  57. import org.openspcoop2.core.registry.GruppoAccordo;
  58. import org.openspcoop2.core.registry.Operation;
  59. import org.openspcoop2.core.registry.PortType;
  60. import org.openspcoop2.core.registry.RegistroServizi;
  61. import org.openspcoop2.core.registry.Resource;
  62. import org.openspcoop2.core.registry.Ruolo;
  63. import org.openspcoop2.core.registry.Scope;
  64. import org.openspcoop2.core.registry.Soggetto;
  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.constants.TipologiaServizio;
  73. import org.openspcoop2.core.registry.driver.BeanUtilities;
  74. import org.openspcoop2.core.registry.driver.DriverRegistroServiziException;
  75. import org.openspcoop2.core.registry.driver.DriverRegistroServiziNotFound;
  76. import org.openspcoop2.core.registry.driver.FiltroRicerca;
  77. import org.openspcoop2.core.registry.driver.FiltroRicercaAccordi;
  78. import org.openspcoop2.core.registry.driver.FiltroRicercaAzioni;
  79. import org.openspcoop2.core.registry.driver.FiltroRicercaFruizioniServizio;
  80. import org.openspcoop2.core.registry.driver.FiltroRicercaGruppi;
  81. import org.openspcoop2.core.registry.driver.FiltroRicercaOperations;
  82. import org.openspcoop2.core.registry.driver.FiltroRicercaPortTypes;
  83. import org.openspcoop2.core.registry.driver.FiltroRicercaResources;
  84. import org.openspcoop2.core.registry.driver.FiltroRicercaRuoli;
  85. import org.openspcoop2.core.registry.driver.FiltroRicercaScope;
  86. import org.openspcoop2.core.registry.driver.FiltroRicercaServizi;
  87. import org.openspcoop2.core.registry.driver.FiltroRicercaSoggetti;
  88. import org.openspcoop2.core.registry.driver.IDAccordoCooperazioneFactory;
  89. import org.openspcoop2.core.registry.driver.IDAccordoFactory;
  90. import org.openspcoop2.core.registry.driver.IDServizioFactory;
  91. import org.openspcoop2.core.registry.driver.IDriverRegistroServiziGet;
  92. import org.openspcoop2.core.registry.driver.ProtocolPropertiesUtilities;
  93. import org.openspcoop2.core.registry.driver.ValidazioneSemantica;
  94. import org.openspcoop2.message.OpenSPCoop2MessageFactory;
  95. import org.openspcoop2.message.xml.ValidatoreXSD;
  96. import org.openspcoop2.utils.LoggerWrapperFactory;
  97. import org.openspcoop2.utils.certificate.ArchiveLoader;
  98. import org.openspcoop2.utils.certificate.ArchiveType;
  99. import org.openspcoop2.utils.certificate.Certificate;
  100. import org.openspcoop2.utils.certificate.CertificateInfo;
  101. import org.openspcoop2.utils.certificate.CertificateUtils;
  102. import org.openspcoop2.utils.certificate.PrincipalType;
  103. import org.openspcoop2.utils.crypt.CryptConfig;
  104. import org.openspcoop2.utils.crypt.CryptFactory;
  105. import org.openspcoop2.utils.crypt.ICrypt;
  106. import org.openspcoop2.utils.date.DateManager;
  107. import org.slf4j.Logger;


  110. /**
  111.  * Classe utilizzata per effettuare query ad un registro dei servizi openspcoop formato da un file xml.
  112.  * Le query riguardano specifiche
  113.  * proprieta' di servizi presenti all'interno del registro.
  114.  *
  115.  *
  116.  * @author Sandra Giangrandi (sandra@link.it)
  117.  * @author Poli Andrea (apoli@link.it)
  118.  * @author $Author$
  119.  * @version $Rev$, $Date$
  120.  */

  122. public class DriverRegistroServiziXML extends BeanUtilities 
  123.     implements IDriverRegistroServiziGet,IMonitoraggioRisorsa {


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

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

  131.     /** Path dove si trova il file xml che realizza il Registro dei servizi OpenSPCoop. */
  132.     private String registry_path;
  133.     /** 'Root' del servizio dei registri OpenSPCoop. */
  134.     private org.openspcoop2.core.registry.RegistroServizi registro;
  135.     /** Validatore della configurazione */
  136.     private ValidatoreXSD validatoreRegistro = null;

  138.     // Factory
  139.     private IDAccordoFactory idAccordoFactory = IDAccordoFactory.getInstance();
  140.     private IDAccordoCooperazioneFactory idAccordoCooperazioneFactory = IDAccordoCooperazioneFactory.getInstance();
  141.     private IDServizioFactory idServizioFactory = IDServizioFactory.getInstance();


  144.     /** Variabile che mantiene uno stato di ultima modifica del registro dei servizi xml
  145.         od una variabile temporale che servira' per fare il refresh della configurazione 
  146.     una volta scaduto un timeout, nel caso il file sia posto in remoto (HTTP) .*/
  147.     private long lastModified = 0;
  148.     /** Logger utilizzato per info. */
  149.     private Logger log = null;
  150.     /** Indica ogni quanto deve essere effettuato il refresh del file dei registri dei servizi, 
  151.     nel caso sia posto in remoto (secondi)*/
  152.     private static final int timeoutRefresh = 30;

  154.     public org.openspcoop2.core.registry.RegistroServizi getRegistroXML() {
  155.         return this.registro;
  156.     }


  159.     /** ************* parsing XML ************** */
  160.     public void parsingXMLRegistroServizi() throws DriverRegistroServiziException{

  162.         /* --- Validazione XSD -- */
  163.         FileInputStream fXML = null;
  164.         try{
  165.             if(this.registry_path.startsWith("http://") || this.registry_path.startsWith("file://")){
  166.                 this.validatoreRegistro.valida(this.registry_path);  
  167.             }else{
  168.                 fXML = new FileInputStream(this.registry_path);
  169.                 this.validatoreRegistro.valida(fXML);
  170.             }
  171.         }catch (Exception e) {
  172.             throw new DriverRegistroServiziException("Riscontrato errore durante la validazione XSD del Registro dei Servizi XML di OpenSPCoop: "+e.getMessage());
  173.         }finally{
  174.             if(fXML!=null){
  175.                 try{
  176.                     fXML.close();
  177.                 }catch(Exception e){}
  178.             }
  179.         }

  181.         /* ---- InputStream ---- */
  182.         InputStream iStream = null;
  183.         HttpURLConnection httpConn = null;
  184.         if(this.registry_path.startsWith("http://") || this.registry_path.startsWith("file://")){
  185.             try{ 
  186.                 URL url = new URL(this.registry_path);
  187.                 URLConnection connection = url.openConnection();
  188.                 httpConn = (HttpURLConnection) connection;
  189.                 httpConn.setRequestMethod("GET");
  190.                 httpConn.setDoOutput(true);
  191.                 httpConn.setDoInput(true);
  192.                 iStream = httpConn.getInputStream();
  193.             }catch(Exception e) {
  194.                 try{  
  195. //                  if(iStream!=null)
  196. //                      iStream.close();
  197.                     if(httpConn !=null)
  198.                         httpConn.disconnect();
  199.                 } catch(Exception ef) {}
  200.                 throw new DriverRegistroServiziException("Riscontrato errore durante la creazione dell'inputStream del registro dei servizi (HTTP) : \n\n"+e.getMessage());
  201.             }
  202.             this.lastModified = DateManager.getTimeMillis();
  203.         }else{
  204.             try{  
  205.                 iStream = new FileInputStream(this.registry_path);
  206.             }catch(java.io.FileNotFoundException e) {
  207.                 throw new DriverRegistroServiziException("Riscontrato errore durante la creazione dell'inputStream del registro dei servizi (FILE) : \n\n"+e.getMessage());
  208.             }
  209.             try{
  210.                 this.lastModified = (new File(this.registry_path)).lastModified();
  211.             }catch(Exception e){
  212.                 try{  
  213.                     if(iStream!=null)
  214.                         iStream.close();
  215.                 } catch(java.io.IOException ef) {}
  216.                 throw new DriverRegistroServiziException("Riscontrato errore durante la lettura del file dove e' allocato il registro dei servizi: "+e.getMessage());
  217.             }
  218.         }



  222.         /* ---- Unmarshall del file di configurazione ---- */
  223.         try{  
  224.             org.openspcoop2.core.registry.utils.serializer.JaxbDeserializer deserializer = new org.openspcoop2.core.registry.utils.serializer.JaxbDeserializer();
  225.             this.registro = deserializer.readRegistroServizi(iStream);
  226.         } catch(Exception e) {
  227.             try{  
  228.                 if(iStream!=null)
  229.                     iStream.close();
  230.             } catch(Exception ef) {}
  231.             try{ 
  232.                 if(httpConn !=null)
  233.                     httpConn.disconnect();
  234.             } catch(Exception ef) {}
  235.             throw new DriverRegistroServiziException("Riscontrato errore durante l'unmarshall del file di configurazione: "+e.getMessage());
  236.         }

  238.         try{  
  239.             // Chiusura dello Stream
  240.             if(iStream!=null)
  241.                 iStream.close();
  242.         } catch(Exception e) {
  243.             throw new DriverRegistroServiziException("Riscontrato errore durante la chiusura dell'Input Stream: "+e.getMessage());
  244.         }
  245.         try{
  246.             // Chiusura dell'eventuale connessione HTTP
  247.             if(httpConn !=null)
  248.                 httpConn.disconnect();
  249.         } catch(Exception e) {
  250.             throw new DriverRegistroServiziException("Riscontrato errore durante la chiusura dell'Input Stream (http): "+e.getMessage());
  251.         }
  252.     }




  257.     /* ********  COSTRUTTORI e METODI DI RELOAD  ******** */

  259.     /**
  260.      * Costruttore.  Viene effettuato l'unmarshall del file di configurazione.
  261.      *
  262.      * @param path path dove si trova il file xml che realizza il Registro dei servizi OpenSPCoop.
  263.      * 
  264.      */
  265.     public DriverRegistroServiziXML(String path,Logger alog){

  267.         if(alog==null)
  268.             this.log = LoggerWrapperFactory.getLogger(DriverRegistroServiziXML.class);
  269.         else
  270.             this.log = alog;

  272.         if(path == null){
  273.             this.log.error("DriverRegistroServizi: Riscontrato errore durante la creazione: url/path is null");
  274.             this.create=false;
  275.             return;
  276.         }
  277.         this.registry_path = path;

  279.         /* --- Costruzione Validatore XSD -- */
  280.         try{
  281.             this.validatoreRegistro = new ValidatoreXSD(OpenSPCoop2MessageFactory.getDefaultMessageFactory(), this.log,DriverRegistroServiziXML.class.getResourceAsStream("/registroServizi.xsd"));
  282.         }catch (Exception e) {
  283.             this.log.error("Riscontrato errore durante l'inizializzazione dello schema del Registro dei Servizi di OpenSPCoop: "+e.getMessage());
  284.             return;
  285.         }

  287.         try{
  288.             this.parsingXMLRegistroServizi();
  289.         }catch(Exception e){
  290.             this.log.error("DriverRegistroServizi: "+e.getMessage());
  291.             this.create=false;
  292.             return;
  293.         }
  294.         this.create = true;
  295.     }

  297.     /**
  298.      * Metodo che si occupa di effettuare il refresh dell'unmarshall del file di configurazione
  299.      * se il file di configurazione e' stato modificato dall'ultimo unmarshall.
  300.      *
  301.      * 
  302.      */
  303.     private void forzaRefreshRegistroServiziXML() throws DriverRegistroServiziException{
  304.         refreshRegistroServiziXML(true);
  305.     }
  306.     /**
  307.      * Metodo che si occupa di effettuare il refresh dell'unmarshall del file di configurazione
  308.      * se il file di configurazione e' stato modificato dall'ultimo unmarshall.
  309.      *
  310.      * 
  311.      */
  312.     public void refreshRegistroServiziXML() throws DriverRegistroServiziException{
  313.         refreshRegistroServiziXML(false);
  314.     }
  315.     /**
  316.      * Metodo che si occupa di effettuare il refresh dell'unmarshall del file di configurazione
  317.      * se il file di configurazione e' stato modificato dall'ultimo unmarshall.
  318.      *
  319.      * 
  320.      */
  321.     private synchronized void refreshRegistroServiziXML(boolean refreshForzato) throws DriverRegistroServiziException{

  323.         File fTest = null;
  324.         boolean refresh = refreshForzato;
  325.         if(refreshForzato==false){
  326.             if(this.registry_path.startsWith("http://") || this.registry_path.startsWith("file://")){
  327.                 long now = DateManager.getTimeMillis();
  328.                 if( (now-this.lastModified) > (DriverRegistroServiziXML.timeoutRefresh*1000) ){
  329.                     refresh=true;
  330.                 }
  331.             }else{
  332.                 fTest = new File(this.registry_path);
  333.                 if(this.lastModified != fTest.lastModified()){
  334.                     refresh = true;
  335.                 }
  336.             }
  337.         }
  338.         if(refresh){

  340.             try{
  341.                 this.parsingXMLRegistroServizi();
  342.             }catch(Exception e){
  343.                 this.log.error("DriverRegistroServizi refreshError: "+e.getMessage());
  344.                 throw new DriverRegistroServiziException("DriverRegistroServizi refreshError: "+e.getMessage());
  345.             }
  346.             if(this.registry_path.startsWith("http://")==false && this.registry_path.startsWith("file://")==false){
  347.                 this.log.warn("Reloaded registry context.");
  348.             }

  350.             if(this.validazioneSemanticaDuranteModificaXML){
  351.                 ValidazioneSemantica validazioneSemantica = new ValidazioneSemantica(this.registro,this.verificaURI,this.tipiConnettori,
  352.                         this.tipiSoggetti,this.tipiServiziSoap,this.tipiServiziRest,
  353.                         this.log);
  354.                 try{
  355.                     validazioneSemantica.validazioneSemantica(false);
  356.                 }catch(Exception e){
  357.                     this.log.error("DriverRegistroServizi refreshError(ValidazioneSemantica): "+e.getMessage());
  358.                     throw new DriverRegistroServiziException("DriverRegistroServizi refreshError(ValidazioneSemantica): "+e.getMessage());
  359.                 }               
  360.             }
  361.             
  362.         }

  364.         if(this.registro == null){
  365.             this.log.error("DriverRegistroServizi refreshError: istanza del registro is null dopo il refresh");
  366.             throw new DriverRegistroServiziException("DriverRegistroServizi refreshError: istanza del registro is null dopo il refresh");
  367.         }

  369.     }

  371.     private boolean validazioneSemanticaDuranteModificaXML = false;
  372.     private boolean verificaURI = false;
  373.     private String[] tipiConnettori = null;
  374.     private String[] tipiSoggetti = null;
  375.     private String[] tipiServiziSoap = null;
  376.     private String[] tipiServiziRest = null;
  377.     public void abilitazioneValidazioneSemanticaDuranteModificaXML(boolean verificaURI, String[] tipiConnettori,
  378.             String[] tipiSoggetti,String [] tipiServiziSoapValidi, String [] tipiServiziRestValidi){
  379.         this.validazioneSemanticaDuranteModificaXML = true;
  380.         this.verificaURI = verificaURI;
  381.         this.tipiConnettori = tipiConnettori;
  382.         this.tipiSoggetti = tipiSoggetti;
  383.         this.tipiServiziSoap = tipiServiziSoapValidi;
  384.         this.tipiServiziRest = tipiServiziRestValidi;
  385.     }
























  410.     /* ********  INTERFACCIA IDriverRegistroServiziGet ******** */ 

  412.     
  413.     
  414.     /* Accordi di Cooperazione */
  415.     
  416.     /**
  417.      * Si occupa di ritornare l'oggetto {@link org.openspcoop2.core.registry.AccordoCooperazione}, 
  418.      * identificato grazie al parametro 
  419.      * <var>nomeAccordo</var> 
  420.      *
  421.      * @param idAccordo Identificativo dell'accordo di Cooperazione
  422.      * @return un oggetto di tipo {@link org.openspcoop2.core.registry.AccordoCooperazione}.
  423.      * 
  424.      */
  425.     @Override
  426.     public org.openspcoop2.core.registry.AccordoCooperazione getAccordoCooperazione(IDAccordoCooperazione idAccordo) throws DriverRegistroServiziException,DriverRegistroServiziNotFound{

  428.         if(idAccordo==null)
  429.             throw new DriverRegistroServiziException("[getAccordoCooperazione] Parametro Non Valido");
  430.         if(idAccordo.getNome()==null)
  431.             throw new DriverRegistroServiziException("[getAccordoCooperazione] Nome accordo non presente");
  432.         
  433.         refreshRegistroServiziXML();

  435.         for(int i=0; i<this.registro.sizeAccordoCooperazioneList(); i++){
  436.             org.openspcoop2.core.registry.AccordoCooperazione ac = this.registro.getAccordoCooperazione(i);
  437.             if (ac.getNome() != null) {
  438.                 if (ac.getNome().equals(idAccordo.getNome())) {
  439.                     
  440.                     // potenziale as, verifico versione
  441.                     if(idAccordo.getVersione()==null){
  442.                         if(ac.getVersione()!=null)
  443.                             continue;
  444.                     }else{
  445.                         if(idAccordo.getVersione().equals(ac.getVersione())==false)
  446.                             continue;
  447.                     }
  448.                     
  449.                     //read uriServiziComposti
  450.                     String uriAccordoCooperazione = this.idAccordoCooperazioneFactory.getUriFromAccordo(ac);
  451.                     for(int j=0; j<this.registro.sizeAccordoServizioParteComuneList(); j++){
  452.                         AccordoServizioParteComune as = this.registro.getAccordoServizioParteComune(j);
  453.                         if(as.getServizioComposto()!=null && uriAccordoCooperazione.equals(as.getServizioComposto().getAccordoCooperazione()) ){
  454.                             // Trovato as composto collegato all'accordo di cooperazione
  455.                             ac.addUriServiziComposti(this.idAccordoFactory.getUriFromAccordo(as));
  456.                         } 
  457.                     }
  458.                     
  459.                     return ac;
  460.                 }
  461.             }
  462.         }

  464.         throw new DriverRegistroServiziNotFound("[getAccordoCooperazione] Accordo di Cooperazione non trovato");
  465.     }

  467.     /**
  468.      * Ritorna gli identificatori degli accordi che rispettano il parametro di ricerca
  469.      * 
  470.      * @param filtroRicerca
  471.      * @return Una lista di ID degli accordi trovati
  472.      * @throws DriverRegistroServiziException
  473.      * @throws DriverRegistroServiziNotFound
  474.      */
  475.     @Override
  476.     public List<IDAccordoCooperazione> getAllIdAccordiCooperazione(FiltroRicercaAccordi filtroRicerca) throws DriverRegistroServiziException,DriverRegistroServiziNotFound{
  477.         try{

  479.             List<IDAccordoCooperazione> idAccordi = new ArrayList<IDAccordoCooperazione>();
  480.             for(int i=0; i<this.registro.sizeAccordoCooperazioneList(); i++){
  481.                 org.openspcoop2.core.registry.AccordoCooperazione ac = this.registro.getAccordoCooperazione(i);
  482.                 String uriAC = this.idAccordoCooperazioneFactory.getUriFromAccordo(ac);
  483.                 
  484.                 if(filtroRicerca!=null){
  485.                     // Filtro By Data
  486.                     if(filtroRicerca.getMinDate()!=null){
  487.                         if(ac.getOraRegistrazione()==null){
  488.                             this.log.debug("[getAllIdAccordiCooperazione](FiltroByMinDate) Accordo di cooperazione ["+uriAC+"] non valorizzato nell'ora-registrazione. Non inserito nella lista ritornata.");
  489.                             continue;
  490.                         }else if(ac.getOraRegistrazione().before(filtroRicerca.getMinDate())){
  491.                             continue;
  492.                         }
  493.                     }
  494.                     if(filtroRicerca.getMaxDate()!=null){
  495.                         if(ac.getOraRegistrazione()==null){
  496.                             this.log.debug("[getAllIdAccordiCooperazione](FiltroByMaxDate) Accordo di cooperazione ["+uriAC+"] non valorizzato nell'ora-registrazione. Non inserito nella lista ritornata.");
  497.                             continue;
  498.                         }else if(ac.getOraRegistrazione().after(filtroRicerca.getMaxDate())){
  499.                             continue;
  500.                         }
  501.                     }
  502.                     // Filtro By Nome
  503.                     if(filtroRicerca.getNomeAccordo()!=null){
  504.                         if(ac.getNome().equals(filtroRicerca.getNomeAccordo()) == false){
  505.                             continue;
  506.                         }
  507.                     }
  508.                     if(filtroRicerca.getVersione()!=null){
  509.                         if(ac.getVersione().equals(filtroRicerca.getVersione()) == false){
  510.                             continue;
  511.                         }
  512.                     }
  513.                     if(filtroRicerca.getTipoSoggettoReferente()!=null || filtroRicerca.getNomeSoggettoReferente()!=null){
  514.                         if(ac.getSoggettoReferente()==null)
  515.                             continue;
  516.                         if(filtroRicerca.getTipoSoggettoReferente()!=null){
  517.                             if(ac.getSoggettoReferente().getTipo().equals(filtroRicerca.getTipoSoggettoReferente()) == false){
  518.                                 continue;
  519.                             }
  520.                         }
  521.                         if(filtroRicerca.getNomeSoggettoReferente()!=null){
  522.                             if(ac.getSoggettoReferente().getNome().equals(filtroRicerca.getNomeSoggettoReferente()) == false){
  523.                                 continue;
  524.                             }
  525.                         }
  526.                     }
  527.                     // ProtocolProperties
  528.                     if(ProtocolPropertiesUtilities.isMatch(ac, filtroRicerca.getProtocolPropertiesAccordo())==false){
  529.                         continue;
  530.                     }
  531.                 }
  532.                 idAccordi.add(this.idAccordoCooperazioneFactory.getIDAccordoFromAccordo(ac));
  533.             }
  534.             if(idAccordi.size()==0){
  535.                 if(filtroRicerca!=null){
  536.                     throw new DriverRegistroServiziNotFound("Accordi di cooperazione non trovati che rispettano il filtro di ricerca selezionato: "+filtroRicerca.toString());
  537.                 }else{
  538.                     throw new DriverRegistroServiziNotFound("Accordi di cooperazione non trovati");
  539.                 }
  540.             }else{
  541.                 return idAccordi;
  542.             }
  543.         }catch(Exception e){
  544.             throw new DriverRegistroServiziException("getAllIdAccordiCooperazione error",e);
  545.         }
  546.     }
  547.     
  548.     
  549.     
  550.     
  551.     
  552.     /* Accordi di Servizio Parte Comune */
  553.     
  554.     /**
  555.      * Si occupa di ritornare l'oggetto {@link org.openspcoop2.core.registry.AccordoServizioParteComune}, 
  556.      * identificato grazie al parametro 
  557.      * <var>nomeAccordo</var> 
  558.      *
  559.      * @param idAccordo Identificativo dell'accordo di Servizio
  560.      * @return un oggetto di tipo {@link org.openspcoop2.core.registry.AccordoServizioParteComune}.
  561.      * 
  562.      */
  563.     @Override
  564.     public org.openspcoop2.core.registry.AccordoServizioParteComune getAccordoServizioParteComune(IDAccordo idAccordo) throws DriverRegistroServiziException,DriverRegistroServiziNotFound{

  566.         if(idAccordo==null)
  567.             throw new DriverRegistroServiziException("[getAccordoServizioParteComune] Parametro Non Valido");
  568.         if(idAccordo.getNome()==null)
  569.             throw new DriverRegistroServiziException("[getAccordoServizioParteComune] Nome accordo non presente");
  570.         IDSoggetto soggettoReferenteCheck = idAccordo.getSoggettoReferente();
  571.         if(soggettoReferenteCheck!=null){
  572.             if(soggettoReferenteCheck.getTipo()==null){
  573.                 throw new DriverRegistroServiziException("[getAccordoServizioParteComune] Tipo soggetto referente non presente?");
  574.             }
  575.             if(soggettoReferenteCheck.getNome()==null){
  576.                 throw new DriverRegistroServiziException("[getAccordoServizioParteComune] Nome soggetto referente non presente?");
  577.             }
  578.         }

  580.         refreshRegistroServiziXML();

  582.         for(int i=0; i<this.registro.sizeAccordoServizioParteComuneList(); i++){
  583.             org.openspcoop2.core.registry.AccordoServizioParteComune as = this.registro.getAccordoServizioParteComune(i);
  584.             if (as.getNome() != null) {
  585.                 if (as.getNome().equals(idAccordo.getNome())) {
  586.                     
  587.                     // potenziale as, verifico soggetto referente e versione
  588.                     if(soggettoReferenteCheck==null){
  589.                         if(as.getSoggettoReferente()!=null)
  590.                             continue;
  591.                     }else{
  592.                         if(as.getSoggettoReferente()==null)
  593.                             continue;
  594.                         if(soggettoReferenteCheck.getTipo().equals(as.getSoggettoReferente().getTipo())==false)
  595.                             continue;
  596.                         if(soggettoReferenteCheck.getNome().equals(as.getSoggettoReferente().getNome())==false)
  597.                             continue;
  598.                     }
  599.                     if(idAccordo.getVersione()==null){
  600.                         if(as.getVersione()!=null)
  601.                             continue;
  602.                     }else{
  603.                         if(idAccordo.getVersione().equals(as.getVersione())==false)
  604.                             continue;
  605.                     }
  606.                     
  607.                     // nomiAzione setting 
  608. //                  as.setNomiAzione(as.readNomiAzione());
  609.                     return as;
  610.                 }
  611.             }
  612.         }

  614.         throw new DriverRegistroServiziNotFound("[getAccordoServizioParteComune] Accordo di Servizio non trovato");
  615.     }

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

  620.         List<IDAccordo> list = new ArrayList<IDAccordo>();
  621.         _fillAllIdAccordiServizioParteComuneEngine("getAllIdAccordiServizioParteComune", filtroRicerca, null, null, null, null, list);
  622.         return list;
  623.     
  624.     }
  625.     
  626.     @Override
  627.     public List<IDPortType> getAllIdPortType(FiltroRicercaPortTypes filtroRicerca) throws DriverRegistroServiziException,DriverRegistroServiziNotFound{
  628.         
  629.         List<IDPortType> list = new ArrayList<IDPortType>();
  630.         _fillAllIdAccordiServizioParteComuneEngine("getAllIdPortType", filtroRicerca, filtroRicerca, null, null, null, list);
  631.         return list;
  632.         
  633.     }
  634.     
  635.     @Override
  636.     public List<IDPortTypeAzione> getAllIdAzionePortType(FiltroRicercaOperations filtroRicerca) throws DriverRegistroServiziException,DriverRegistroServiziNotFound{
  637.     
  638.         List<IDPortTypeAzione> list = new ArrayList<IDPortTypeAzione>();
  639.         _fillAllIdAccordiServizioParteComuneEngine("getAllIdAzionePortType", filtroRicerca, null, filtroRicerca, null, null, list);
  640.         return list;
  641.         
  642.     }
  643.     
  644.     @Override
  645.     public List<IDAccordoAzione> getAllIdAzioneAccordo(FiltroRicercaAzioni filtroRicerca) throws DriverRegistroServiziException,DriverRegistroServiziNotFound{
  646.         
  647.         List<IDAccordoAzione> list = new ArrayList<IDAccordoAzione>();
  648.         _fillAllIdAccordiServizioParteComuneEngine("getAllIdAzioneAccordo", filtroRicerca, null, null, filtroRicerca, null, list);
  649.         return list;
  650.         
  651.     }
  652.     
  653.     @Override
  654.     public List<IDResource> getAllIdResource(FiltroRicercaResources filtroRicerca) throws DriverRegistroServiziException,DriverRegistroServiziNotFound{
  655.         
  656.         List<IDResource> list = new ArrayList<IDResource>();
  657.         _fillAllIdAccordiServizioParteComuneEngine("getAllIdResource", filtroRicerca, null, null, null, filtroRicerca, list);
  658.         return list;
  659.         
  660.     }
  661.     
  662.     @SuppressWarnings("unchecked")
  663.     public <T> void _fillAllIdAccordiServizioParteComuneEngine(String nomeMetodo, 
  664.             FiltroRicercaAccordi filtroRicercaBase,
  665.             FiltroRicercaPortTypes filtroPT, FiltroRicercaOperations filtroOP, FiltroRicercaAzioni filtroAZ,
  666.             FiltroRicercaResources filtroResource,
  667.             List<T> listReturn) throws DriverRegistroServiziException,DriverRegistroServiziNotFound{
  668.         try{

  670.             for(int i=0; i<this.registro.sizeAccordoServizioParteComuneList(); i++){
  671.                 org.openspcoop2.core.registry.AccordoServizioParteComune as = this.registro.getAccordoServizioParteComune(i);
  672.                 String uriAS = this.idAccordoFactory.getUriFromAccordo(as);
  673.                 
  674.                 if(filtroRicercaBase!=null){
  675.                     
  676.                     List<String> tipoSoggettiProtocollo = null;
  677.                     try {
  678.                         if(filtroRicercaBase!=null && (filtroRicercaBase.getProtocollo()!=null || (filtroRicercaBase.getProtocolli()!=null && !filtroRicercaBase.getProtocolli().isEmpty()))){
  679.                             tipoSoggettiProtocollo = Filtri.convertToTipiSoggetti(filtroRicercaBase.getProtocollo(), Filtri.convertToString(filtroRicercaBase.getProtocolli()));
  680.                         }
  681.                     }catch(Exception e) {
  682.                         throw new DriverRegistroServiziException(e.getMessage(),e);
  683.                     }
  684.                     boolean searchByTipoSoggetto = (tipoSoggettiProtocollo!=null && tipoSoggettiProtocollo.size()>0);
  685.                     
  686.                     // Filtro By Data
  687.                     if(filtroRicercaBase.getMinDate()!=null){
  688.                         if(as.getOraRegistrazione()==null){
  689.                             this.log.debug("["+nomeMetodo+"](FiltroByMinDate) Accordo di servizio ["+uriAS+"] non valorizzato nell'ora-registrazione. Non inserito nella lista ritornata.");
  690.                             continue;
  691.                         }else if(as.getOraRegistrazione().before(filtroRicercaBase.getMinDate())){
  692.                             continue;
  693.                         }
  694.                     }
  695.                     if(filtroRicercaBase.getMaxDate()!=null){
  696.                         if(as.getOraRegistrazione()==null){
  697.                             this.log.debug("["+nomeMetodo+"](FiltroByMaxDate) Accordo di servizio ["+uriAS+"] non valorizzato nell'ora-registrazione. Non inserito nella lista ritornata.");
  698.                             continue;
  699.                         }else if(as.getOraRegistrazione().after(filtroRicercaBase.getMaxDate())){
  700.                             continue;
  701.                         }
  702.                     }
  703.                     // Filtro By Nome
  704.                     if(filtroRicercaBase.getNomeAccordo()!=null){
  705.                         if(as.getNome().equals(filtroRicercaBase.getNomeAccordo()) == false){
  706.                             continue;
  707.                         }
  708.                     }
  709.                     if(filtroRicercaBase.getVersione()!=null){
  710.                         if(as.getVersione().equals(filtroRicercaBase.getVersione()) == false){
  711.                             continue;
  712.                         }
  713.                     }
  714.                     if(searchByTipoSoggetto || filtroRicercaBase.getTipoSoggettoReferente()!=null || filtroRicercaBase.getNomeSoggettoReferente()!=null){
  715.                         if(as.getSoggettoReferente()==null)
  716.                             continue;
  717.                         if(filtroRicercaBase.getTipoSoggettoReferente()!=null){
  718.                             if(as.getSoggettoReferente().getTipo().equals(filtroRicercaBase.getTipoSoggettoReferente()) == false){
  719.                                 continue;
  720.                             }
  721.                         }
  722.                         else if(searchByTipoSoggetto) {
  723.                             boolean find = false;
  724.                             for (String tipoSoggettoProtocollo : tipoSoggettiProtocollo) {
  725.                                 if(as.getSoggettoReferente().getTipo().equals(tipoSoggettoProtocollo)){
  726.                                     find = true;
  727.                                     break;
  728.                                 }
  729.                             }
  730.                             if(!find) {
  731.                                 continue;
  732.                             }
  733.                         }
  734.                         if(filtroRicercaBase.getNomeSoggettoReferente()!=null){
  735.                             if(as.getSoggettoReferente().getNome().equals(filtroRicercaBase.getNomeSoggettoReferente()) == false){
  736.                                 continue;
  737.                             }
  738.                         }
  739.                     }
  740.                     if(filtroRicercaBase.getServiceBinding()!=null){
  741.                         if(as.getServiceBinding().equals(filtroRicercaBase.getServiceBinding()) == false){
  742.                             continue;
  743.                         }
  744.                     }
  745.                     
  746.                     if(filtroRicercaBase.getIdGruppo()!=null && filtroRicercaBase.getIdGruppo().getNome()!=null){
  747.                         boolean found = false;
  748.                         if(as.getGruppi()!=null && as.getGruppi().sizeGruppoList()>0) {
  749.                             for (GruppoAccordo gruppo : as.getGruppi().getGruppoList()) {
  750.                                 if(gruppo.getNome().equals(filtroRicercaBase.getIdGruppo().getNome())) {
  751.                                     found = true;
  752.                                     break;
  753.                                 }
  754.                             }
  755.                         }
  756.                         if(!found) {
  757.                             continue;
  758.                         }
  759.                     }
  760.                     
  761.                     if(filtroRicercaBase.getIdAccordoCooperazione()!=null &&
  762.                             (filtroRicercaBase.getIdAccordoCooperazione().getNome()!=null || 
  763.                             filtroRicercaBase.getIdAccordoCooperazione().getVersione()!=null) ){
  764.                         if(as.getServizioComposto()==null){
  765.                             continue;
  766.                         }
  767.                         IDAccordoCooperazione idAC = this.idAccordoCooperazioneFactory.getIDAccordoFromUri(as.getServizioComposto().getAccordoCooperazione());
  768.                         if(filtroRicercaBase.getIdAccordoCooperazione().getNome()!=null){
  769.                             if(idAC.getNome().equals(filtroRicercaBase.getIdAccordoCooperazione().getNome())== false){
  770.                                 continue;
  771.                             }
  772.                         }
  773.                         if(filtroRicercaBase.getIdAccordoCooperazione().getVersione()!=null){
  774.                             if(idAC.getVersione().equals(filtroRicercaBase.getIdAccordoCooperazione().getVersione())== false){
  775.                                 continue;
  776.                             }
  777.                         }
  778.                     }
  779.                     else if(filtroRicercaBase.isServizioComposto()!=null){
  780.                         if(filtroRicercaBase.isServizioComposto()){
  781.                             if(as.getServizioComposto()==null){
  782.                                 continue;
  783.                             }
  784.                         }
  785.                         else {
  786.                             if(as.getServizioComposto()!=null){
  787.                                 continue;
  788.                             }
  789.                         }
  790.                     }
  791.                     
  792.                     // ProtocolProperties
  793.                     if(ProtocolPropertiesUtilities.isMatch(as, filtroRicercaBase.getProtocolPropertiesAccordo())==false){
  794.                         continue;
  795.                     }
  796.                     
  797.                 }
  798.                 
  799.                 IDAccordo idAccordo = this.idAccordoFactory.getIDAccordoFromAccordo(as);
  800.                 
  801.                 if(filtroPT!=null){
  802.                     for (PortType pt : as.getPortTypeList()) {
  803.                         // Nome PT
  804.                         if(filtroPT.getNomePortType()!=null){
  805.                             if(pt.getNome().equals(filtroPT.getNomePortType()) == false){
  806.                                 continue;
  807.                             }
  808.                         }
  809.                         // ProtocolProperties PT
  810.                         if(ProtocolPropertiesUtilities.isMatch(pt, filtroPT.getProtocolPropertiesPortType())==false){
  811.                             continue;
  812.                         }
  813.                         
  814.                         IDPortType idPT = new IDPortType();
  815.                         idPT.setIdAccordo(idAccordo);
  816.                         idPT.setNome(pt.getNome());
  817.                         listReturn.add((T)idPT);
  818.                     }
  819.                 }
  820.                 else if(filtroOP!=null){
  821.                     for (PortType pt : as.getPortTypeList()) {
  822.                         
  823.                         // Nome PT
  824.                         if(filtroOP.getNomePortType()!=null){
  825.                             if(pt.getNome().equals(filtroOP.getNomePortType()) == false){
  826.                                 continue;
  827.                             }
  828.                         }
  829.                         // ProtocolProperties PT
  830.                         if(ProtocolPropertiesUtilities.isMatch(pt, filtroOP.getProtocolPropertiesPortType())==false){
  831.                             continue;
  832.                         }
  833.                         
  834.                         for (Operation op : pt.getAzioneList()) {
  835.                             
  836.                             // Nome OP
  837.                             if(filtroOP.getNomeAzione()!=null){
  838.                                 if(op.getNome().equals(filtroOP.getNomeAzione()) == false){
  839.                                     continue;
  840.                                 }
  841.                             }
  842.                             // ProtocolProperties OP
  843.                             if(ProtocolPropertiesUtilities.isMatch(pt, filtroOP.getProtocolPropertiesAzione())==false){
  844.                                 continue;
  845.                             }
  846.                         
  847.                             IDPortTypeAzione idAzione = new IDPortTypeAzione();
  848.                             IDPortType idPT = new IDPortType();
  849.                             idPT.setIdAccordo(idAccordo);
  850.                             idPT.setNome(pt.getNome());
  851.                             idAzione.setIdPortType(idPT);
  852.                             idAzione.setNome(op.getNome());
  853.                             listReturn.add((T)idAzione);
  854.                         }
  855.                     }
  856.                 }
  857.                 else if(filtroAZ!=null){
  858.                     for (Azione az : as.getAzioneList()) {
  859.                         
  860.                         // Nome AZ
  861.                         if(filtroAZ.getNomeAzione()!=null){
  862.                             if(az.getNome().equals(filtroAZ.getNomeAzione()) == false){
  863.                                 continue;
  864.                             }
  865.                         }
  866.                         // ProtocolProperties PT
  867.                         if(ProtocolPropertiesUtilities.isMatch(az, filtroAZ.getProtocolPropertiesAzione())==false){
  868.                             continue;
  869.                         }
  870.                         
  871.                         IDAccordoAzione idAzione = new IDAccordoAzione();
  872.                         idAzione.setIdAccordo(idAccordo);
  873.                         idAzione.setNome(az.getNome());
  874.                         listReturn.add((T)idAzione);
  875.                     }
  876.                 }
  877.                 else if(filtroResource!=null){
  878.                     for (Resource resource : as.getResourceList()) {
  879.                         // Nome Risorsa
  880.                         if(filtroResource.getResourceName()!=null){
  881.                             if(resource.getNome().equals(filtroResource.getResourceName()) == false){
  882.                                 continue;
  883.                             }
  884.                         }
  885.                         // ProtocolProperties PT
  886.                         if(ProtocolPropertiesUtilities.isMatch(resource, filtroResource.getProtocolPropertiesResources())==false){
  887.                             continue;
  888.                         }
  889.                         
  890.                         IDResource idResource = new IDResource();
  891.                         idResource.setIdAccordo(idAccordo);
  892.                         idResource.setNome(resource.getNome());
  893.                         listReturn.add((T)idResource);
  894.                     }
  895.                 }
  896.                 else{
  897.                     listReturn.add((T)idAccordo);
  898.                 }
  899.             }
  900.             if(listReturn.size()<=0){
  901.                 String msgFiltro = "Elementi non trovati che rispettano il filtro di ricerca selezionato: ";
  902.                 if(filtroPT!=null){
  903.                     throw new DriverRegistroServiziNotFound(msgFiltro+filtroPT.toString());
  904.                 }
  905.                 else if(filtroOP!=null){
  906.                     throw new DriverRegistroServiziNotFound(msgFiltro+filtroOP.toString());
  907.                 }
  908.                 else if(filtroAZ!=null){
  909.                     throw new DriverRegistroServiziNotFound(msgFiltro+filtroAZ.toString());
  910.                 }
  911.                 else if(filtroRicercaBase!=null){
  912.                     throw new DriverRegistroServiziNotFound(msgFiltro+filtroRicercaBase.toString());
  913.                 }
  914.                 else{
  915.                     throw new DriverRegistroServiziNotFound("Elementi non trovati");
  916.                 }
  917.             }
  918.         }catch(Exception e){
  919.             throw new DriverRegistroServiziException(nomeMetodo+" error",e);
  920.         }
  921.     }

  923.     
  924.     @Override
  925.     public Documento getAllegato(IDAccordo idAccordo, String nome) throws DriverRegistroServiziException,DriverRegistroServiziNotFound{
  926.         org.openspcoop2.core.registry.AccordoServizioParteComune aspc = getAccordoServizioParteComune(idAccordo);
  927.         if(aspc.sizeAllegatoList()>0) {
  928.             for (Documento doc : aspc.getAllegatoList()) {
  929.                 File f = new File(doc.getFile());
  930.                 if(nome.equals(doc.getFile()) || nome.equals(f.getName())) {
  931.                     return doc;
  932.                 }
  933.             }
  934.         }
  935.         throw new DriverRegistroServiziNotFound("Documento '"+nome+"' non trovato");
  936.     }
  937.     @Override
  938.     public Documento getSpecificaSemiformale(IDAccordo idAccordo, TipiDocumentoSemiformale tipo, String nome)throws DriverRegistroServiziException,DriverRegistroServiziNotFound{
  939.         org.openspcoop2.core.registry.AccordoServizioParteComune aspc = getAccordoServizioParteComune(idAccordo);
  940.         if(aspc.sizeSpecificaSemiformaleList()>0) {
  941.             for (Documento doc : aspc.getSpecificaSemiformaleList()) {
  942.                 File f = new File(doc.getFile());
  943.                 if(nome.equals(doc.getFile()) || nome.equals(f.getName())) {
  944.                     if(tipo!=null && tipo.getNome().equals(doc.getTipo())) {
  945.                         return doc;
  946.                     }
  947.                 }
  948.             }
  949.         }
  950.         throw new DriverRegistroServiziNotFound("Documento '"+nome+"' non trovato");
  951.     }
  952.     
  953.     
  954.     
  955.     
  956.     /* Porte di Dominio */
  957.     
  958.     /**
  959.      * Si occupa di ritornare l'oggetto {@link org.openspcoop2.core.registry.PortaDominio}, 
  960.      * identificato grazie al parametro 
  961.      * <var>nomePdD</var> 
  962.      *
  963.      * @param nomePdD Nome della Porta di Dominio
  964.      * @return un oggetto di tipo {@link org.openspcoop2.core.registry.PortaDominio}.
  965.      * 
  966.      */
  967.     @Override
  968.     public org.openspcoop2.core.registry.PortaDominio getPortaDominio(String nomePdD) throws DriverRegistroServiziException,DriverRegistroServiziNotFound{
  969.         
  970.         if(nomePdD==null)
  971.             throw new DriverRegistroServiziException("[getPortaDominio] Parametro Non Valido");

  973.         refreshRegistroServiziXML();

  975.         for(int i=0; i<this.registro.sizePortaDominioList(); i++){
  976.             org.openspcoop2.core.registry.PortaDominio pd = this.registro.getPortaDominio(i);
  977.             if (pd.getNome() != null) {
  978.                 if (pd.getNome().equals(nomePdD)) {
  979.                     return pd;
  980.                 }
  981.             }
  982.         }

  984.         throw new DriverRegistroServiziNotFound("[getPortaDominio] Porta di Dominio non trovata");
  985.     }

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

  999.             List<String> nomiPorteDiDominio = new ArrayList<>();
  1000.             for(int i=0; i<this.registro.sizePortaDominioList(); i++){
  1001.                 org.openspcoop2.core.registry.PortaDominio pd = this.registro.getPortaDominio(i);
  1002.                 if(filtroRicerca!=null){
  1003.                     // Filtro By Data
  1004.                     if(filtroRicerca.getMinDate()!=null){
  1005.                         if(pd.getOraRegistrazione()==null){
  1006.                             this.log.debug("[getAllIdPorteDominio](FiltroByMinDate) Porta di Dominio ["+pd.getNome()+"] non valorizzata nell'ora-registrazione. Non inserito nella lista ritornata.");
  1007.                             continue;
  1008.                         }else if(pd.getOraRegistrazione().before(filtroRicerca.getMinDate())){
  1009.                             continue;
  1010.                         }
  1011.                     }
  1012.                     if(filtroRicerca.getMaxDate()!=null){
  1013.                         if(pd.getOraRegistrazione()==null){
  1014.                             this.log.debug("[getAllIdPorteDominio](FiltroByMaxDate) Porta di Dominio ["+pd.getNome()+"] non valorizzata nell'ora-registrazione. Non inserito nella lista ritornata.");
  1015.                             continue;
  1016.                         }else if(pd.getOraRegistrazione().after(filtroRicerca.getMaxDate())){
  1017.                             continue;
  1018.                         }
  1019.                     }
  1020.                     // Filtro By Nome
  1021.                     if(filtroRicerca.getNome()!=null){
  1022.                         if(pd.getNome().equals(filtroRicerca.getNome()) == false){
  1023.                             continue;
  1024.                         }
  1025.                     }
  1026.                 }
  1027.                 nomiPorteDiDominio.add(pd.getNome());
  1028.             }
  1029.             if(nomiPorteDiDominio.size()==0){
  1030.                 if(filtroRicerca!=null){
  1031.                     throw new DriverRegistroServiziNotFound("Porte di Dominio non trovate che rispettano il filtro di ricerca selezionato: "+filtroRicerca.toString());
  1032.                 }else{
  1033.                     throw new DriverRegistroServiziNotFound("Porte di Dominio non trovate");
  1034.                 }
  1035.             }else{
  1036.                 return nomiPorteDiDominio;
  1037.             }
  1038.         }catch(Exception e){
  1039.             throw new DriverRegistroServiziException("getAllIdPorteDominio error",e);
  1040.         }
  1041.     }
  1042.     
  1043.     
  1044.     
  1045.     
  1046.     
  1047.     
  1048.     
  1049.     
  1050.     
  1051.     
  1052.     /* Gruppi */
  1053.     
  1054.     /**
  1055.      * Si occupa di ritornare l'oggetto {@link org.openspcoop2.core.registry.Gruppo}, 
  1056.      * identificato grazie al parametro 
  1057.      * <var>nome</var> 
  1058.      *
  1059.      * @param idGruppo Identificativo del gruppo
  1060.      * @return un oggetto di tipo {@link org.openspcoop2.core.registry.Gruppo}.
  1061.      * 
  1062.      */
  1063.     @Override
  1064.     public Gruppo getGruppo(
  1065.             IDGruppo idGruppo) throws DriverRegistroServiziException, DriverRegistroServiziNotFound{
  1066.         
  1067.         if(idGruppo==null || idGruppo.getNome()==null)
  1068.             throw new DriverRegistroServiziException("[getGruppo] Parametro Non Valido");

  1070.         refreshRegistroServiziXML();

  1072.         for(int i=0; i<this.registro.sizeGruppoList(); i++){
  1073.             org.openspcoop2.core.registry.Gruppo gruppo = this.registro.getGruppo(i);
  1074.             if (gruppo.getNome() != null) {
  1075.                 if (gruppo.getNome().equals(idGruppo.getNome())) {
  1076.                     return gruppo;
  1077.                 }
  1078.             }
  1079.         }

  1081.         throw new DriverRegistroServiziNotFound("[getGruppo] Gruppo non trovato");
  1082.     }

  1084.     /**
  1085.      * Ritorna gli identificatori dei Gruppi che rispettano il parametro di ricerca
  1086.      * 
  1087.      * @param filtroRicerca
  1088.      * @return Una lista di ID dei gruppi trovati
  1089.      * @throws DriverRegistroServiziException
  1090.      * @throws DriverRegistroServiziNotFound
  1091.      */
  1092.     @Override
  1093.     public List<IDGruppo> getAllIdGruppi(
  1094.             FiltroRicercaGruppi filtroRicerca) throws DriverRegistroServiziException, DriverRegistroServiziNotFound{
  1095.         try{

  1097.             List<IDGruppo> idGruppi = new ArrayList<IDGruppo>();
  1098.             for(int i=0; i<this.registro.sizeGruppoList(); i++){
  1099.                 org.openspcoop2.core.registry.Gruppo gruppo = this.registro.getGruppo(i);
  1100.                 if(filtroRicerca!=null){
  1101.                     // Filtro By Data
  1102.                     if(filtroRicerca.getMinDate()!=null){
  1103.                         if(gruppo.getOraRegistrazione()==null){
  1104.                             this.log.debug("[getAllIdGruppi](FiltroByMinDate) Gruppo ["+gruppo.getNome()+"] non valorizzato nell'ora-registrazione. Non inserito nella lista ritornata.");
  1105.                             continue;
  1106.                         }else if(gruppo.getOraRegistrazione().before(filtroRicerca.getMinDate())){
  1107.                             continue;
  1108.                         }
  1109.                     }
  1110.                     if(filtroRicerca.getMaxDate()!=null){
  1111.                         if(gruppo.getOraRegistrazione()==null){
  1112.                             this.log.debug("[getAllIdGruppi](FiltroByMaxDate) Gruppo ["+gruppo.getNome()+"] non valorizzato nell'ora-registrazione. Non inserito nella lista ritornata.");
  1113.                             continue;
  1114.                         }else if(gruppo.getOraRegistrazione().after(filtroRicerca.getMaxDate())){
  1115.                             continue;
  1116.                         }
  1117.                     }
  1118.                     // Filtro By Nome
  1119.                     if(filtroRicerca.getNome()!=null){
  1120.                         if(gruppo.getNome().equals(filtroRicerca.getNome()) == false){
  1121.                             continue;
  1122.                         }
  1123.                     }
  1124.                     // Filtro By ServiceBinding
  1125.                     if(filtroRicerca.getServiceBinding()!=null){
  1126.                         if(gruppo.getServiceBinding()!=null){ // se e' uguale a null significa che va bene per qualsiasi service binding
  1127.                             if(gruppo.getServiceBinding().equals(filtroRicerca.getServiceBinding()) == false) {
  1128.                                 continue;
  1129.                             }
  1130.                         }
  1131.                     }
  1132.                 }
  1133.                 IDGruppo id = new IDGruppo(gruppo.getNome());
  1134.                 idGruppi.add(id);
  1135.             }
  1136.             if(idGruppi.size()==0){
  1137.                 if(filtroRicerca!=null){
  1138.                     throw new DriverRegistroServiziNotFound("Gruppi non trovati che rispettano il filtro di ricerca selezionato: "+filtroRicerca.toString());
  1139.                 }else{
  1140.                     throw new DriverRegistroServiziNotFound("Gruppi non trovati");
  1141.                 }
  1142.             }else{
  1143.                 return idGruppi;
  1144.             }
  1145.         }catch(Exception e){
  1146.             throw new DriverRegistroServiziException("getAllIdGruppi error",e);
  1147.         }
  1148.     }
  1149.     
  1150.     
  1151.     
  1152.     
  1153.     
  1154.     
  1155.     
  1156.     
  1157.         
  1158.     /* Ruoli */
  1159.     
  1160.     /**
  1161.      * Si occupa di ritornare l'oggetto {@link org.openspcoop2.core.registry.Ruolo}, 
  1162.      * identificato grazie al parametro 
  1163.      * <var>nome</var> 
  1164.      *
  1165.      * @param idRuolo Identificativo del ruolo
  1166.      * @return un oggetto di tipo {@link org.openspcoop2.core.registry.Ruolo}.
  1167.      * 
  1168.      */
  1169.     @Override
  1170.     public Ruolo getRuolo(
  1171.             IDRuolo idRuolo) throws DriverRegistroServiziException, DriverRegistroServiziNotFound{
  1172.         
  1173.         if(idRuolo==null || idRuolo.getNome()==null)
  1174.             throw new DriverRegistroServiziException("[getRuolo] Parametro Non Valido");

  1176.         refreshRegistroServiziXML();

  1178.         for(int i=0; i<this.registro.sizeRuoloList(); i++){
  1179.             org.openspcoop2.core.registry.Ruolo ruolo = this.registro.getRuolo(i);
  1180.             if (ruolo.getNome() != null) {
  1181.                 if (ruolo.getNome().equals(idRuolo.getNome())) {
  1182.                     return ruolo;
  1183.                 }
  1184.             }
  1185.         }

  1187.         throw new DriverRegistroServiziNotFound("[getRuolo] Ruolo non trovato");
  1188.     }

  1190.     /**
  1191.      * Ritorna gli identificatori dei Ruoli che rispettano il parametro di ricerca
  1192.      * 
  1193.      * @param filtroRicerca
  1194.      * @return Una lista di ID dei ruoli trovati
  1195.      * @throws DriverRegistroServiziException
  1196.      * @throws DriverRegistroServiziNotFound
  1197.      */
  1198.     @Override
  1199.     public List<IDRuolo> getAllIdRuoli(
  1200.             FiltroRicercaRuoli filtroRicerca) throws DriverRegistroServiziException, DriverRegistroServiziNotFound{
  1201.         try{

  1203.             List<IDRuolo> idRuoli = new ArrayList<IDRuolo>();
  1204.             for(int i=0; i<this.registro.sizeRuoloList(); i++){
  1205.                 org.openspcoop2.core.registry.Ruolo ruolo = this.registro.getRuolo(i);
  1206.                 if(filtroRicerca!=null){
  1207.                     // Filtro By Data
  1208.                     if(filtroRicerca.getMinDate()!=null){
  1209.                         if(ruolo.getOraRegistrazione()==null){
  1210.                             this.log.debug("[getAllIdRuoli](FiltroByMinDate) Ruolo ["+ruolo.getNome()+"] non valorizzato nell'ora-registrazione. Non inserito nella lista ritornata.");
  1211.                             continue;
  1212.                         }else if(ruolo.getOraRegistrazione().before(filtroRicerca.getMinDate())){
  1213.                             continue;
  1214.                         }
  1215.                     }
  1216.                     if(filtroRicerca.getMaxDate()!=null){
  1217.                         if(ruolo.getOraRegistrazione()==null){
  1218.                             this.log.debug("[getAllIdRuoli](FiltroByMaxDate) Ruolo ["+ruolo.getNome()+"] non valorizzato nell'ora-registrazione. Non inserito nella lista ritornata.");
  1219.                             continue;
  1220.                         }else if(ruolo.getOraRegistrazione().after(filtroRicerca.getMaxDate())){
  1221.                             continue;
  1222.                         }
  1223.                     }
  1224.                     // Filtro By Nome
  1225.                     if(filtroRicerca.getNome()!=null){
  1226.                         if(ruolo.getNome().equals(filtroRicerca.getNome()) == false){
  1227.                             continue;
  1228.                         }
  1229.                     }
  1230.                     // Filtro By Tipologia
  1231.                     if(filtroRicerca.getTipologia()!=null && !RuoloTipologia.QUALSIASI.equals(filtroRicerca.getTipologia())){
  1232.                         if(ruolo.getTipologia()==null){
  1233.                             continue;
  1234.                         }
  1235.                         if(!RuoloTipologia.QUALSIASI.equals(ruolo.getTipologia())){
  1236.                             if(ruolo.getTipologia().equals(filtroRicerca.getTipologia()) == false){
  1237.                                 continue;
  1238.                             }
  1239.                         }
  1240.                     }
  1241.                     // Filtro By Contesto
  1242.                     if(filtroRicerca.getContesto()!=null && !RuoloContesto.QUALSIASI.equals(filtroRicerca.getContesto())){
  1243.                         if(ruolo.getContestoUtilizzo()==null){
  1244.                             continue;
  1245.                         }
  1246.                         if(!RuoloContesto.QUALSIASI.equals(ruolo.getContestoUtilizzo())){
  1247.                             if(ruolo.getContestoUtilizzo().equals(filtroRicerca.getContesto()) == false){
  1248.                                 continue;
  1249.                             }
  1250.                         }
  1251.                     }
  1252.                 }
  1253.                 IDRuolo id = new IDRuolo(ruolo.getNome());
  1254.                 idRuoli.add(id);
  1255.             }
  1256.             if(idRuoli.size()==0){
  1257.                 if(filtroRicerca!=null){
  1258.                     throw new DriverRegistroServiziNotFound("Ruoli non trovati che rispettano il filtro di ricerca selezionato: "+filtroRicerca.toString());
  1259.                 }else{
  1260.                     throw new DriverRegistroServiziNotFound("Ruoli non trovati");
  1261.                 }
  1262.             }else{
  1263.                 return idRuoli;
  1264.             }
  1265.         }catch(Exception e){
  1266.             throw new DriverRegistroServiziException("getAllIdRuoli error",e);
  1267.         }
  1268.     }
  1269.     
  1270.     
  1271.     
  1272.     
  1273.     
  1274.     
  1275.     
  1276.     /* Scope */
  1277.     
  1278.     /**
  1279.      * Si occupa di ritornare l'oggetto {@link org.openspcoop2.core.registry.Scope}, 
  1280.      * identificato grazie al parametro 
  1281.      * <var>nome</var> 
  1282.      *
  1283.      * @param idScope Identificativo del scope
  1284.      * @return un oggetto di tipo {@link org.openspcoop2.core.registry.Scope}.
  1285.      * 
  1286.      */
  1287.     @Override
  1288.     public Scope getScope(
  1289.             IDScope idScope) throws DriverRegistroServiziException, DriverRegistroServiziNotFound{
  1290.         
  1291.         if(idScope==null || idScope.getNome()==null)
  1292.             throw new DriverRegistroServiziException("[getScope] Parametro Non Valido");

  1294.         refreshRegistroServiziXML();

  1296.         for(int i=0; i<this.registro.sizeScopeList(); i++){
  1297.             org.openspcoop2.core.registry.Scope scope = this.registro.getScope(i);
  1298.             if (scope.getNome() != null) {
  1299.                 if (scope.getNome().equals(idScope.getNome())) {
  1300.                     return scope;
  1301.                 }
  1302.             }
  1303.         }

  1305.         throw new DriverRegistroServiziNotFound("[getScope] Scope non trovato");
  1306.     }

  1308.     /**
  1309.      * Ritorna gli identificatori dei Scope che rispettano il parametro di ricerca
  1310.      * 
  1311.      * @param filtroRicerca
  1312.      * @return Una lista di ID dei scope trovati
  1313.      * @throws DriverRegistroServiziException
  1314.      * @throws DriverRegistroServiziNotFound
  1315.      */
  1316.     @Override
  1317.     public List<IDScope> getAllIdScope(
  1318.             FiltroRicercaScope filtroRicerca) throws DriverRegistroServiziException, DriverRegistroServiziNotFound{
  1319.         try{

  1321.             List<IDScope> idScope = new ArrayList<IDScope>();
  1322.             for(int i=0; i<this.registro.sizeScopeList(); i++){
  1323.                 org.openspcoop2.core.registry.Scope scope = this.registro.getScope(i);
  1324.                 if(filtroRicerca!=null){
  1325.                     // Filtro By Data
  1326.                     if(filtroRicerca.getMinDate()!=null){
  1327.                         if(scope.getOraRegistrazione()==null){
  1328.                             this.log.debug("[getAllIdScope](FiltroByMinDate) Scope ["+scope.getNome()+"] non valorizzato nell'ora-registrazione. Non inserito nella lista ritornata.");
  1329.                             continue;
  1330.                         }else if(scope.getOraRegistrazione().before(filtroRicerca.getMinDate())){
  1331.                             continue;
  1332.                         }
  1333.                     }
  1334.                     if(filtroRicerca.getMaxDate()!=null){
  1335.                         if(scope.getOraRegistrazione()==null){
  1336.                             this.log.debug("[getAllIdScope](FiltroByMaxDate) Scope ["+scope.getNome()+"] non valorizzato nell'ora-registrazione. Non inserito nella lista ritornata.");
  1337.                             continue;
  1338.                         }else if(scope.getOraRegistrazione().after(filtroRicerca.getMaxDate())){
  1339.                             continue;
  1340.                         }
  1341.                     }
  1342.                     // Filtro By Nome
  1343.                     if(filtroRicerca.getNome()!=null){
  1344.                         if(scope.getNome().equals(filtroRicerca.getNome()) == false){
  1345.                             continue;
  1346.                         }
  1347.                     }
  1348.                     // Filtro By Tipologia
  1349.                     if(filtroRicerca.getTipologia()!=null){
  1350.                         if(scope.getTipologia()==null){
  1351.                             continue;
  1352.                         }
  1353.                         if(scope.getTipologia().equals(filtroRicerca.getTipologia()) == false){
  1354.                             continue;
  1355.                         }
  1356.                     }
  1357.                     // Filtro By Contesto
  1358.                     if(filtroRicerca.getContesto()!=null && !ScopeContesto.QUALSIASI.equals(filtroRicerca.getContesto())){
  1359.                         if(scope.getContestoUtilizzo()==null){
  1360.                             continue;
  1361.                         }
  1362.                         if(!ScopeContesto.QUALSIASI.equals(scope.getContestoUtilizzo())){
  1363.                             if(scope.getContestoUtilizzo().equals(filtroRicerca.getContesto()) == false){
  1364.                                 continue;
  1365.                             }
  1366.                         }
  1367.                     }
  1368.                 }
  1369.                 IDScope id = new IDScope(scope.getNome());
  1370.                 idScope.add(id);
  1371.             }
  1372.             if(idScope.size()==0){
  1373.                 if(filtroRicerca!=null){
  1374.                     throw new DriverRegistroServiziNotFound("Scope non trovati che rispettano il filtro di ricerca selezionato: "+filtroRicerca.toString());
  1375.                 }else{
  1376.                     throw new DriverRegistroServiziNotFound("Scope non trovati");
  1377.                 }
  1378.             }else{
  1379.                 return idScope;
  1380.             }
  1381.         }catch(Exception e){
  1382.             throw new DriverRegistroServiziException("getAllIdScope error",e);
  1383.         }
  1384.     }
  1385.     
  1386.     
  1387.     
  1388.     

  1390.     
  1391.     /* Soggetti */

  1393.     /**
  1394.      * Si occupa di ritornare l'oggetto {@link org.openspcoop2.core.registry.Soggetto}, 
  1395.      * identificato grazie al parametro 
  1396.      * <var>idSoggetto</var> di tipo {@link org.openspcoop2.core.id.IDSoggetto}. 
  1397.      *
  1398.      * @param idSoggetto Identificatore del Soggetto di tipo {@link org.openspcoop2.core.id.IDSoggetto}.
  1399.      * @return l'oggetto di tipo {@link org.openspcoop2.core.registry.Soggetto}
  1400.      * 
  1401.      */
  1402.     @Override
  1403.     public org.openspcoop2.core.registry.Soggetto getSoggetto(IDSoggetto idSoggetto) throws DriverRegistroServiziException,DriverRegistroServiziNotFound{

  1405.         if(idSoggetto==null)
  1406.             throw new DriverRegistroServiziException("[getSoggetto] Parametro Non Valido");
  1407.         String tipoSP = idSoggetto.getTipo();
  1408.         String codiceSP = idSoggetto.getNome();
  1409.         if(tipoSP == null || codiceSP == null)
  1410.             throw new DriverRegistroServiziException("[getSoggetto] Parametri Non Validi");

  1412.         refreshRegistroServiziXML();

  1414.         for(int i=0; i<this.registro.sizeSoggettoList(); i++){
  1415.             org.openspcoop2.core.registry.Soggetto ss = this.registro.getSoggetto(i);
  1416.             
  1417.             if( (ss.getTipo() != null) && 
  1418.                     (ss.getNome() != null) ){
  1419.                 if( (ss.getTipo().equals(tipoSP)) && 
  1420.                         (ss.getNome().equals(codiceSP)) ){
  1421.                     return ss;
  1422.                 }
  1423.             }
  1424.         }

  1426.         throw new DriverRegistroServiziNotFound("[getSoggetto] Soggetto non trovato");
  1427.     }
  1428.     
  1429.     @Override
  1430.     public Soggetto getSoggettoByCredenzialiBasic(
  1431.             String user,String password, CryptConfig config) throws DriverRegistroServiziException, DriverRegistroServiziNotFound{
  1432.         return this.getEngineSoggettoAutenticato(CredenzialeTipo.BASIC, user, password, 
  1433.                 null, null, null, false,
  1434.                 null,
  1435.                 config,
  1436.                 false);
  1437.     }
  1438.     
  1439.     @Override
  1440.     public Soggetto getSoggettoByCredenzialiApiKey(
  1441.             String user,String password, boolean appId, CryptConfig config) throws DriverRegistroServiziException, DriverRegistroServiziNotFound{
  1442.         return this.getEngineSoggettoAutenticato(CredenzialeTipo.APIKEY, user, password, 
  1443.                 null, null, null, false,
  1444.                 null,
  1445.                 config,
  1446.                 appId);
  1447.     }
  1448.     
  1449.     @Override
  1450.     public Soggetto getSoggettoByCredenzialiSsl(
  1451.             String subject, String issuer) throws DriverRegistroServiziException, DriverRegistroServiziNotFound{
  1452.         return this.getEngineSoggettoAutenticato(CredenzialeTipo.SSL, null, null, 
  1453.                 subject, issuer, null, false,
  1454.                 null,
  1455.                 null,
  1456.                 false);
  1457.     }
  1458.     
  1459.     @Override
  1460.     public Soggetto getSoggettoByCredenzialiSsl(
  1461.             CertificateInfo certificate, boolean strictVerifier) throws DriverRegistroServiziException, DriverRegistroServiziNotFound{
  1462.         return this.getEngineSoggettoAutenticato(CredenzialeTipo.SSL, null, null, 
  1463.                 null, null, certificate, strictVerifier,
  1464.                 null,
  1465.                 null,
  1466.                 false);
  1467.     }
  1468.     
  1469.     @Override
  1470.     public Soggetto getSoggettoByCredenzialiPrincipal(
  1471.             String principal) throws DriverRegistroServiziException, DriverRegistroServiziNotFound{
  1472.         return this.getEngineSoggettoAutenticato(CredenzialeTipo.PRINCIPAL, null, null, 
  1473.                 null, null, null, false,
  1474.                 principal,
  1475.                 null,
  1476.                 false);
  1477.     }
  1478.     
  1479.     private org.openspcoop2.core.registry.Soggetto getEngineSoggettoAutenticato(CredenzialeTipo tipoCredenziale, String user,String password, 
  1480.             String aSubject, String aIssuer, CertificateInfo aCertificate, boolean aStrictVerifier, 
  1481.             String principal, 
  1482.             CryptConfig config,
  1483.             boolean appId) throws DriverRegistroServiziException,DriverRegistroServiziNotFound{

  1485.         // conrollo consistenza
  1486.         if (tipoCredenziale == null)
  1487.             throw new DriverRegistroServiziException("[getSoggettoAutenticato] Parametro tipoCredenziale is null");

  1489.         switch (tipoCredenziale) {
  1490.         case BASIC:
  1491.             if (user == null || "".equalsIgnoreCase(user))
  1492.                 throw new DriverRegistroServiziException("[getSoggettoAutenticato] Parametro user is null (required for basic auth)");
  1493.             if (password == null || "".equalsIgnoreCase(password))
  1494.                 throw new DriverRegistroServiziException("[getSoggettoAutenticato] Parametro password is null (required for basic auth)");
  1495.             break;
  1496.         case APIKEY:
  1497.             if (user == null || "".equalsIgnoreCase(user))
  1498.                 throw new DriverRegistroServiziException("[getSoggettoAutenticato] Parametro user is null (required for apikey auth)");
  1499.             if (password == null || "".equalsIgnoreCase(password))
  1500.                 throw new DriverRegistroServiziException("[getSoggettoAutenticato] Parametro password is null (required for apikey auth)");
  1501.             break;
  1502.         case SSL:
  1503.             if ( (aSubject == null || "".equalsIgnoreCase(aSubject)) && (aCertificate==null))
  1504.                 throw new DriverRegistroServiziException("[getSoggettoAutenticato] Parametro subject/certificate is null (required for ssl auth)");
  1505.             break;
  1506.         case PRINCIPAL:
  1507.             if (principal == null || "".equalsIgnoreCase(principal))
  1508.                 throw new DriverRegistroServiziException("[getSoggettoAutenticato] Parametro principal is null (required for principal auth)");
  1509.             break;
  1510.         }

  1512.         refreshRegistroServiziXML();

  1514.         boolean testInChiaro = false;
  1515.         ICrypt crypt = null;
  1516.         if(CredenzialeTipo.BASIC.equals(tipoCredenziale)) {
  1517.             if(config==null || config.isBackwardCompatibility()) {
  1518.                 testInChiaro = true;
  1519.             }
  1520.             if(config!=null) {
  1521.                 try {
  1522.                     crypt = CryptFactory.getCrypt(this.log, config);
  1523.                 }catch(Exception e) {
  1524.                     throw new DriverRegistroServiziException(e.getMessage(),e);
  1525.                 }
  1526.             }
  1527.         }
  1528.         else if(CredenzialeTipo.APIKEY.equals(tipoCredenziale)) {
  1529.             if(config!=null) {
  1530.                 try {
  1531.                     crypt = CryptFactory.getCrypt(this.log, config);
  1532.                 }catch(Exception e) {
  1533.                     throw new DriverRegistroServiziException(e.getMessage(),e);
  1534.                 }
  1535.             }
  1536.             else {
  1537.                 testInChiaro = true;
  1538.             }
  1539.         }
  1540.         
  1541.         for(int i=0; i<this.registro.sizeSoggettoList(); i++){
  1542.             org.openspcoop2.core.registry.Soggetto ss = this.registro.getSoggetto(i);
  1543.             CredenzialiSoggetto credenziali = (ss.sizeCredenzialiList() > 0 ? ss.getCredenziali(0) : null);
  1544.             if(credenziali==null){
  1545.                 continue;
  1546.             }
  1547.             if(credenziali.getTipo()==null){
  1548.                 if(tipoCredenziale.equals(CredenzialeTipo.SSL) == false){ // ssl è il default
  1549.                     continue;
  1550.                 }   
  1551.             }
  1552.             if(tipoCredenziale.equals(credenziali.getTipo())==false){
  1553.                 continue;
  1554.             }
  1555.             
  1556.             switch (tipoCredenziale) {
  1557.             case BASIC:
  1558.             case APIKEY:
  1559.                 if( (user.equals(credenziali.getUser()))){
  1560.                     
  1561.                     if(CredenzialeTipo.APIKEY.equals(tipoCredenziale)) {
  1562.                         if(appId) {
  1563.                             if(!credenziali.isAppId()) {
  1564.                                 continue;
  1565.                             }
  1566.                         }
  1567.                         else {
  1568.                             if(credenziali.isAppId()) {
  1569.                                 continue;
  1570.                             }
  1571.                         }
  1572.                     }
  1573.                     
  1574.                     String passwordSaved =  credenziali.getPassword();
  1575.                     
  1576.                     boolean found = false;
  1577.                     if(testInChiaro) {
  1578.                         found = password.equals(passwordSaved);
  1579.                     }
  1580.                     if(!found && crypt!=null) {
  1581.                         found = crypt.check(password, passwordSaved);
  1582.                     }
  1583.                     
  1584.                     if( found ) {
  1585.                         return ss;
  1586.                     }
  1587.                     
  1588.                 }
  1589.                 break;
  1590.             case SSL:
  1591.                 try{
  1592.                     if(aSubject!=null && !"".equals(aSubject)) {
  1593.                     
  1594.                         boolean subjectValid = false;
  1595.                         if(credenziali.getSubject()!=null) {
  1596.                             subjectValid = CertificateUtils.sslVerify(credenziali.getSubject(), aSubject, PrincipalType.SUBJECT, this.log);
  1597.                         }
  1598.                         
  1599.                         boolean issuerValid = true;
  1600.                         if(aIssuer!=null && !"".equals(aIssuer)) {
  1601.                             if(credenziali.getIssuer()==null) {
  1602.                                 issuerValid = false;
  1603.                             }
  1604.                             else {
  1605.                                 issuerValid = CertificateUtils.sslVerify(credenziali.getIssuer(), aIssuer, PrincipalType.ISSUER, this.log);
  1606.                             }
  1607.                         }
  1608.                         else {
  1609.                             issuerValid = (credenziali.getIssuer() == null);
  1610.                         }
  1611.                         
  1612.                         if(subjectValid && issuerValid){
  1613.                             return ss;
  1614.                         }
  1615.     
  1616.                     }
  1617.                     else {
  1618.                         
  1619.                         // ricerca per certificato
  1620.                         String cnSubject = aCertificate.getSubject().getCN();
  1621.                         if(cnSubject.equals(credenziali.getCnSubject())) {
  1622.                             Certificate certificato = ArchiveLoader.load(ArchiveType.CER, credenziali.getCertificate(), 0, null);
  1623.                             if(aCertificate.equals(certificato.getCertificate(),aStrictVerifier)) {
  1624.                                 return ss;
  1625.                             }
  1626.                         }
  1627.                         
  1628.                     }
  1629.                 }catch(Exception e){
  1630.                     throw new DriverRegistroServiziException(e.getMessage(),e);
  1631.                 }
  1632.                 break;
  1633.             case PRINCIPAL:
  1634.                 if( (principal.equals(credenziali.getUser()))){
  1635.                     return ss;
  1636.                 }
  1637.                 break;
  1638.             }
  1639.         }

  1641.         throw new DriverRegistroServiziNotFound("[getSoggetto] Soggetto non Trovato");
  1642.     }

  1644.     /**
  1645.      *  Ritorna gli identificatori dei soggetti che rispettano il parametro di ricerca
  1646.      * 
  1647.      * @param filtroRicerca
  1648.      * @return Una lista di ID dei soggetti trovati
  1649.      * @throws DriverRegistroServiziException
  1650.      * @throws DriverRegistroServiziNotFound
  1651.      */
  1652.     @Override
  1653.     public List<IDSoggetto> getAllIdSoggetti(FiltroRicercaSoggetti filtroRicerca) throws DriverRegistroServiziException,DriverRegistroServiziNotFound{
  1654.         try{
  1655.             
  1656.             boolean testInChiaro = false;
  1657.             ICrypt crypt = null;
  1658.             if(filtroRicerca!=null && filtroRicerca.getCredenzialiSoggetto()!=null && filtroRicerca.getCredenzialiSoggetto().getPassword()!=null){
  1659.                 CredenzialeTipo cTipo = filtroRicerca.getCredenzialiSoggetto().getTipo();
  1660.                 if(CredenzialeTipo.BASIC.equals(cTipo)){
  1661.                     CryptConfig config = filtroRicerca.getCryptConfig();
  1662.                     if(config==null || config.isBackwardCompatibility()) {
  1663.                         testInChiaro = true;
  1664.                     }
  1665.                     if(config!=null) {
  1666.                         try {
  1667.                             crypt = CryptFactory.getCrypt(this.log, config);
  1668.                         }catch(Exception e) {
  1669.                             throw new DriverRegistroServiziException(e.getMessage(),e);
  1670.                         }
  1671.                     }
  1672.                 }
  1673.                 else if(CredenzialeTipo.APIKEY.equals(cTipo)){
  1674.                     CryptConfig config = filtroRicerca.getCryptConfig();
  1675.                     if(config!=null) {
  1676.                         try {
  1677.                             crypt = CryptFactory.getCrypt(this.log, config);
  1678.                         }catch(Exception e) {
  1679.                             throw new DriverRegistroServiziException(e.getMessage(),e);
  1680.                         }
  1681.                     }
  1682.                     else {
  1683.                         testInChiaro = true;
  1684.                     }
  1685.                 }
  1686.             }
  1687.             
  1688.             List<IDSoggetto> idSoggetti = new ArrayList<IDSoggetto>();
  1689.             for(int i=0; i<this.registro.sizeSoggettoList(); i++){
  1690.                 org.openspcoop2.core.registry.Soggetto ss = this.registro.getSoggetto(i);
  1691.                 if(filtroRicerca!=null){
  1692.                     // Filtro By Data
  1693.                     if(filtroRicerca.getMinDate()!=null){
  1694.                         if(ss.getOraRegistrazione()==null){
  1695.                             this.log.debug("[getAllIdSoggetti](FiltroByMinDate) Soggetto ["+ss.getTipo()+"/"+ss.getNome()+"] non valorizzato nell'ora-registrazione. Non inserito nella lista ritornata.");
  1696.                             continue;
  1697.                         }else if(ss.getOraRegistrazione().before(filtroRicerca.getMinDate())){
  1698.                             continue;
  1699.                         }
  1700.                     }
  1701.                     if(filtroRicerca.getMaxDate()!=null){
  1702.                         if(ss.getOraRegistrazione()==null){
  1703.                             this.log.debug("[getAllIdSoggetti](FiltroByMaxDate) Soggetto ["+ss.getTipo()+"/"+ss.getNome()+"] non valorizzato nell'ora-registrazione. Non inserito nella lista ritornata.");
  1704.                             continue;
  1705.                         }else if(ss.getOraRegistrazione().after(filtroRicerca.getMaxDate())){
  1706.                             continue;
  1707.                         }
  1708.                     }
  1709.                     // Filtro By Tipo e Nome
  1710.                     if(filtroRicerca.getTipo()!=null){
  1711.                         if(ss.getTipo().equals(filtroRicerca.getTipo()) == false){
  1712.                             continue;
  1713.                         }
  1714.                     }
  1715.                     if(filtroRicerca.getNome()!=null){
  1716.                         if(ss.getNome().equals(filtroRicerca.getNome()) == false){
  1717.                             continue;
  1718.                         }
  1719.                     }
  1720.                     // Filtro By Pdd
  1721.                     if(filtroRicerca.getNomePdd()!=null){
  1722.                         if(ss.getPortaDominio().equals(filtroRicerca.getNomePdd()) == false){
  1723.                             continue;
  1724.                         }
  1725.                     }
  1726.                     // ProtocolProperties
  1727.                     if(ProtocolPropertiesUtilities.isMatch(ss, filtroRicerca.getProtocolProperties())==false){
  1728.                         continue;
  1729.                     }
  1730.                     // Filtro By Ruoli
  1731.                     if(filtroRicerca.getIdRuolo()!=null && filtroRicerca.getIdRuolo().getNome()!=null){
  1732.                         if(ss.getRuoli()==null){
  1733.                             continue;
  1734.                         }
  1735.                         boolean contains = false;
  1736.                         for (int j = 0; j < ss.getRuoli().sizeRuoloList(); j++) {
  1737.                             if(filtroRicerca.getIdRuolo().getNome().equals(ss.getRuoli().getRuolo(j).getNome())){
  1738.                                 contains = true;
  1739.                                 break;
  1740.                             }
  1741.                         }
  1742.                         if(!contains){
  1743.                             continue;
  1744.                         }
  1745.                     }
  1746.                     // Filtro By Credenziali
  1747.                     if(filtroRicerca.getCredenzialiSoggetto()!=null){
  1748.                         CredenzialiSoggetto credenziali = (ss.sizeCredenzialiList() > 0 ? ss.getCredenziali(0) : null);
  1749.                         if(credenziali==null){
  1750.                             continue;
  1751.                         }
  1752.                         if(filtroRicerca.getCredenzialiSoggetto().getTipo()!=null){
  1753.                             if(credenziali.getTipo()==null){
  1754.                                 if(filtroRicerca.getCredenzialiSoggetto().getTipo().equals(CredenzialeTipo.SSL) == false){ // ssl è il default
  1755.                                     continue;
  1756.                                 }
  1757.                             }
  1758.                             else{
  1759.                                 if(filtroRicerca.getCredenzialiSoggetto().getTipo().equals(credenziali.getTipo())==false){
  1760.                                     continue;
  1761.                                 }
  1762.                                 if(CredenzialeTipo.APIKEY.equals(filtroRicerca.getCredenzialiSoggetto().getTipo())){
  1763.                                     if(filtroRicerca.getCredenzialiSoggetto().isAppId()) {
  1764.                                         if(!credenziali.isAppId()) {
  1765.                                             continue;
  1766.                                         }
  1767.                                     }
  1768.                                     else {
  1769.                                         if(credenziali.isAppId()) {
  1770.                                             continue;
  1771.                                         }
  1772.                                     }
  1773.                                 }
  1774.                             }
  1775.                         }
  1776.                         if(filtroRicerca.getCredenzialiSoggetto().getUser()!=null){
  1777.                             if(filtroRicerca.getCredenzialiSoggetto().getUser().equals(credenziali.getUser())==false){
  1778.                                 continue;
  1779.                             }
  1780.                         }
  1781.                         if(filtroRicerca.getCredenzialiSoggetto().getPassword()!=null){
  1782.                             String passwordSaved =  credenziali.getPassword();
  1783.                             boolean found = false;
  1784.                             if(testInChiaro) {
  1785.                                 found = filtroRicerca.getCredenzialiSoggetto().getPassword().equals(passwordSaved);
  1786.                             }
  1787.                             if(!found && crypt!=null) {
  1788.                                 found = crypt.check(filtroRicerca.getCredenzialiSoggetto().getPassword(), passwordSaved);
  1789.                             }
  1790.                             
  1791.                             if( !found ) {
  1792.                                 continue;
  1793.                             }
  1794.                         }
  1795.                         if(filtroRicerca.getCredenzialiSoggetto().getSubject()!=null){
  1796.                             try{
  1797.                                 if(credenziali.getSubject()==null){
  1798.                                     continue;
  1799.                                 }
  1800.                                 boolean subjectValid = CertificateUtils.sslVerify(credenziali.getSubject(), filtroRicerca.getCredenzialiSoggetto().getSubject(), PrincipalType.SUBJECT, this.log);
  1801.                                 boolean issuerValid = true;
  1802.                                 if(filtroRicerca.getCredenzialiSoggetto().getIssuer()!=null) {
  1803.                                     if(credenziali.getIssuer()==null) {
  1804.                                         issuerValid = false;
  1805.                                     }
  1806.                                     else {
  1807.                                         issuerValid = CertificateUtils.sslVerify(credenziali.getIssuer(), filtroRicerca.getCredenzialiSoggetto().getIssuer(), PrincipalType.ISSUER, this.log);
  1808.                                     }
  1809.                                 }
  1810.                                 else {
  1811.                                     issuerValid = (credenziali.getIssuer() == null);
  1812.                                 }
  1813.                                 if(!subjectValid || !issuerValid){
  1814.                                     continue;
  1815.                                 }
  1816.                             }catch(Exception e){
  1817.                                 throw new DriverRegistroServiziException(e.getMessage(),e);
  1818.                             }
  1819.                         }
  1820.                         if(filtroRicerca.getCredenzialiSoggetto().getCnSubject()!=null && filtroRicerca.getCredenzialiSoggetto().getCertificate()!=null) {
  1821.                             if(filtroRicerca.getCredenzialiSoggetto().getCnSubject().equals(credenziali.getCnSubject())==false) {
  1822.                                 continue;
  1823.                             }
  1824.                             // Possono esistere piu' soggetti che hanno un CN con subject e issuer diverso.
  1825.                             Certificate certificato = ArchiveLoader.load(ArchiveType.CER, credenziali.getCertificate(), 0, null);
  1826.                             Certificate certificatoFiltro = ArchiveLoader.load(ArchiveType.CER, filtroRicerca.getCredenzialiSoggetto().getCertificate(), 0, null);                          
  1827.                             if(!certificatoFiltro.getCertificate().equals(certificato.getCertificate(),filtroRicerca.getCredenzialiSoggetto().isCertificateStrictVerification())) {
  1828.                                 continue;
  1829.                             }
  1830.                         }
  1831.                         
  1832.                     }
  1833.                 }
  1834.                 IDSoggetto idS = new IDSoggetto(ss.getTipo(),ss.getNome());
  1835.                 idSoggetti.add(idS);
  1836.             }
  1837.             if(idSoggetti.size()==0){
  1838.                 if(filtroRicerca!=null){
  1839.                     throw new DriverRegistroServiziNotFound("Soggetti non trovati che rispettano il filtro di ricerca selezionato: "+filtroRicerca.toString());
  1840.                 }else{
  1841.                     throw new DriverRegistroServiziNotFound("Soggetti non trovati");
  1842.                 }
  1843.             }else{
  1844.                 return idSoggetti;
  1845.             }
  1846.         }catch(Exception e){
  1847.             throw new DriverRegistroServiziException("getAllIdSoggetti error",e);
  1848.         }
  1849.     }

  1851.     
  1852.     
  1853.     
  1854.     
  1855.     
  1856.     /* Accordi di Servizio Parte Specifica */
  1857.     
  1858.     /**
  1859.      * Si occupa di ritornare l'oggetto {@link org.openspcoop2.core.registry.AccordoServizioParteSpecifica}
  1860.      * contenente le informazioni sulle funzionalita' associate
  1861.      * al servizio  identificato grazie ai fields Soggetto,
  1862.      * 'Servizio','TipoServizio' e 'Azione' impostati
  1863.      * all'interno del parametro <var>idService</var> di tipo {@link org.openspcoop2.core.id.IDServizio}. 
  1864.      *
  1865.      * @param idService Identificatore del Servizio di tipo {@link org.openspcoop2.core.id.IDServizio}.
  1866.      * @return l'oggetto di tipo {@link org.openspcoop2.core.registry.AccordoServizioParteSpecifica}
  1867.      * 
  1868.      */
  1869.     @Override
  1870.     public org.openspcoop2.core.registry.AccordoServizioParteSpecifica getAccordoServizioParteSpecifica(IDServizio idService) throws DriverRegistroServiziException,DriverRegistroServiziNotFound{

  1872.         // Il refresh viene effettuato con questa ricerca.
  1873.         org.openspcoop2.core.registry.Soggetto soggetto = getSoggetto(idService.getSoggettoErogatore());

  1875.         if(soggetto == null)
  1876.             throw new DriverRegistroServiziException("[getAccordoServizioParteSpecifica(IDServizio)] Parametro Non Valido");
  1877.         String servizio = idService.getNome();
  1878.         String tipoServizio = idService.getTipo();
  1879.         Integer versioneServizio = idService.getVersione();
  1880.         if((servizio==null)||(tipoServizio==null)||(versioneServizio==null))
  1881.             throw new DriverRegistroServiziException("[getAccordoServizioParteSpecifica(IDServizio)] Parametri Non Validi");

  1883.         for(int i=0; i<soggetto.sizeAccordoServizioParteSpecificaList(); i++){
  1884.             org.openspcoop2.core.registry.AccordoServizioParteSpecifica asps = soggetto.getAccordoServizioParteSpecifica(i);
  1885.             if( (asps.getTipo().equals(tipoServizio)) && 
  1886.                     (asps.getNome().equals(servizio)) &&
  1887.                     asps.getVersione().intValue() == versioneServizio.intValue()){
  1888.                 asps.setTipoSoggettoErogatore(soggetto.getTipo());
  1889.                 asps.setNomeSoggettoErogatore(soggetto.getNome());
  1890.                 return asps;
  1891.             }
  1892.         }

  1894.         throw new DriverRegistroServiziNotFound("[getAccordoServizioParteSpecifica(IDServizio)] Servizio non trovato");
  1895.     }


  1898.     /**
  1899.      * Si occupa di ritornare l'oggetto {@link org.openspcoop2.core.registry.AccordoServizioParteSpecifica}
  1900.      * contenente le informazioni sulle funzionalita' associate
  1901.      * al servizio  correlato identificato grazie ai fields Soggetto
  1902.      * e nomeAccordo
  1903.      * 
  1904.      * @param idSoggetto Identificatore del Soggetto di tipo {@link org.openspcoop2.core.id.IDSoggetto}.
  1905.      * @param idAccordoServizioParteComune ID dell'accordo che deve implementare il servizio correlato
  1906.      * @return l'oggetto di tipo {@link org.openspcoop2.core.registry.AccordoServizioParteSpecifica}.
  1907.      * 
  1908.      */
  1909.     @Override
  1910.     public AccordoServizioParteSpecifica getAccordoServizioParteSpecifica_ServizioCorrelato(
  1911.             IDSoggetto idSoggetto, 
  1912.             IDAccordo idAccordoServizioParteComune) throws DriverRegistroServiziException, DriverRegistroServiziNotFound{
  1913.         
  1914.         // Il refresh viene effettuato con questa ricerca.
  1915.         org.openspcoop2.core.registry.Soggetto soggetto = getSoggetto(idSoggetto);
  1916.         if(soggetto == null)
  1917.             throw new DriverRegistroServiziException("[getAccordoServizioParteSpecifica_ServizioCorrelato] Parametro Non Valido");

  1919.         String uriAccordo = this.idAccordoFactory.getUriFromIDAccordo(idAccordoServizioParteComune);
  1920.         
  1921.         for(int i=0; i<soggetto.sizeAccordoServizioParteSpecificaList(); i++){
  1922.             org.openspcoop2.core.registry.AccordoServizioParteSpecifica asps = soggetto.getAccordoServizioParteSpecifica(i);
  1923.             if( asps.getAccordoServizioParteComune() != null) {
  1924.                 if( asps.getAccordoServizioParteComune().equals(uriAccordo) && TipologiaServizio.CORRELATO.equals(asps.getTipologiaServizio()) ) {
  1925.                     asps.setTipoSoggettoErogatore(soggetto.getTipo());
  1926.                     asps.setNomeSoggettoErogatore(soggetto.getNome());
  1927.                     return asps;
  1928.                 }
  1929.             }
  1930.         }

  1932.         throw new DriverRegistroServiziNotFound("[getAccordoServizioParteSpecifica_ServizioCorrelato] Servizio non trovato");
  1933.         
  1934.     }
  1935.     
  1936.     
  1937.     @Override
  1938.     public List<IDServizio> getAllIdServizi(FiltroRicercaServizi filtroRicerca) throws DriverRegistroServiziException, DriverRegistroServiziNotFound{
  1939.         
  1940.         List<IDServizio> list = new ArrayList<IDServizio>();
  1941.         _fillAllIdServiziEngine("getAllIdServizi", filtroRicerca, list);
  1942.         return list;
  1943.         
  1944.     }
  1945.     
  1946.     @Override
  1947.     public List<IDFruizione> getAllIdFruizioniServizio(
  1948.             FiltroRicercaFruizioniServizio filtroRicerca) throws DriverRegistroServiziException, DriverRegistroServiziNotFound{
  1949.     
  1950.         List<IDFruizione> list = new ArrayList<IDFruizione>();
  1951.         _fillAllIdServiziEngine("getAllIdFruizioniServizio", filtroRicerca, list);
  1952.         return list;
  1953.         
  1954.     }
  1955.     
  1956.     @SuppressWarnings("unchecked")
  1957.     public <T> void _fillAllIdServiziEngine(String nomeMetodo, 
  1958.             FiltroRicercaServizi filtroRicerca,
  1959.             List<T> listReturn) throws DriverRegistroServiziException,DriverRegistroServiziNotFound{
  1960.         try{

  1962.             FiltroRicercaFruizioniServizio filtroFruizioni = null;
  1963.             if(filtroRicerca instanceof FiltroRicercaFruizioniServizio){
  1964.                 filtroFruizioni = (FiltroRicercaFruizioniServizio) filtroRicerca;
  1965.             }
  1966.             
  1967.             for(int i=0; i<this.registro.sizeSoggettoList(); i++){
  1968.                 org.openspcoop2.core.registry.Soggetto ss = this.registro.getSoggetto(i);
  1969.                 if(filtroRicerca!=null){
  1970.                     // Filtro By Tipo e Nome Soggetto Erogatore
  1971.                     if(filtroRicerca.getTipoSoggettoErogatore()!=null){
  1972.                         if(ss.getTipo().equals(filtroRicerca.getTipoSoggettoErogatore()) == false){
  1973.                             continue;
  1974.                         }
  1975.                     }
  1976.                     if(filtroRicerca.getNomeSoggettoErogatore()!=null){
  1977.                         if(ss.getNome().equals(filtroRicerca.getNomeSoggettoErogatore()) == false){
  1978.                             continue;
  1979.                         }
  1980.                     }
  1981.                 }
  1982.                 for(int j=0; j<ss.sizeAccordoServizioParteSpecificaList(); j++){
  1983.                     org.openspcoop2.core.registry.AccordoServizioParteSpecifica asps = ss.getAccordoServizioParteSpecifica(j);

  1985.                     if(filtroRicerca!=null){
  1986.                         // Filtro By Data
  1987.                         if(filtroRicerca.getMinDate()!=null){
  1988.                             if(asps.getOraRegistrazione()==null){
  1989.                                 this.log.debug("["+nomeMetodo+"](FiltroByMinDate) Servizio["+this.idServizioFactory.getUriFromAccordo(asps)+"] non valorizzato nell'ora-registrazione. Non inserito nella lista ritornata.");
  1990.                                 continue;
  1991.                             }else if(asps.getOraRegistrazione().before(filtroRicerca.getMinDate())){
  1992.                                 continue;
  1993.                             }
  1994.                         }
  1995.                         if(filtroRicerca.getMaxDate()!=null){
  1996.                             if(asps.getOraRegistrazione()==null){
  1997.                                 this.log.debug("["+nomeMetodo+"](FiltroByMaxDate) Servizio["+this.idServizioFactory.getUriFromAccordo(asps)+"] non valorizzato nell'ora-registrazione. Non inserito nella lista ritornata.");
  1998.                                 continue;
  1999.                             }else if(asps.getOraRegistrazione().after(filtroRicerca.getMaxDate())){
  2000.                                 continue;
  2001.                             }
  2002.                         }
  2003.                         // Filtro By Tipo, Nome e Versione
  2004.                         if(filtroRicerca.getTipo()!=null){
  2005.                             if(asps.getTipo().equals(filtroRicerca.getTipo()) == false){
  2006.                                 continue;
  2007.                             }
  2008.                         }
  2009.                         if(filtroRicerca.getNome()!=null){
  2010.                             if(asps.getNome().equals(filtroRicerca.getNome()) == false){
  2011.                                 continue;
  2012.                             }
  2013.                         }
  2014.                         if(filtroRicerca.getVersione()!=null){
  2015.                             if(asps.getVersione().intValue() != filtroRicerca.getVersione().intValue()){
  2016.                                 continue;
  2017.                             }
  2018.                         }
  2019.                         if(filtroRicerca.getPortType()!=null){
  2020.                             if(asps.getPortType().equals(filtroRicerca.getPortType()) == false){
  2021.                                 continue;
  2022.                             }
  2023.                         }
  2024.                         // Filtro by Accordo
  2025.                         if(filtroRicerca.getIdAccordoServizioParteComune()!=null){
  2026.                             String uriAccordo = this.idAccordoFactory.getUriFromIDAccordo(filtroRicerca.getIdAccordoServizioParteComune());
  2027.                             if(asps.getAccordoServizioParteComune().equals(uriAccordo) == false){
  2028.                                 continue;
  2029.                             }
  2030.                         }
  2031.                         // ProtocolProperties
  2032.                         if(ProtocolPropertiesUtilities.isMatch(asps, filtroRicerca.getProtocolProperties())==false){
  2033.                             continue;
  2034.                         }
  2035.                         // Filtro By Tipo e/o Nome Soggetto Fruitore
  2036.                         if(filtroRicerca.getTipoSoggettoFruitore()!=null || filtroRicerca.getNomeSoggettoFruitore()!=null){
  2037.                             if(asps.sizeFruitoreList()<=0){
  2038.                                 continue;
  2039.                             }
  2040.                             boolean found = false;
  2041.                             for (int k = 0; k < asps.sizeFruitoreList(); k++) {
  2042.                                 Fruitore fruitore = asps.getFruitore(k);
  2043.                                 if(filtroRicerca.getTipoSoggettoFruitore()!=null){
  2044.                                     if(fruitore.getTipo().equals(filtroRicerca.getTipoSoggettoFruitore()) == false){
  2045.                                         continue;
  2046.                                     }
  2047.                                 }
  2048.                                 if(filtroRicerca.getNomeSoggettoFruitore()!=null){
  2049.                                     if(fruitore.getNome().equals(filtroRicerca.getNomeSoggettoFruitore()) == false){
  2050.                                         continue;
  2051.                                     }
  2052.                                 }
  2053.                                 found = true;
  2054.                                 break;
  2055.                             }
  2056.                             if(!found){
  2057.                                 continue;
  2058.                             }
  2059.                         }
  2060.                     }
  2061.                     IDServizio idServ = this.idServizioFactory.getIDServizioFromAccordo(asps);
  2062.                     
  2063.                     if(filtroFruizioni!=null){
  2064.                         
  2065.                         for (Fruitore fruitore : asps.getFruitoreList()) {
  2066.                             
  2067.                             // Tipo
  2068.                             if(filtroFruizioni.getTipoSoggettoFruitore()!=null){
  2069.                                 if(fruitore.getTipo().equals(filtroFruizioni.getTipoSoggettoFruitore()) == false){
  2070.                                     continue;
  2071.                                 }
  2072.                             }
  2073.                             // Nome
  2074.                             if(filtroFruizioni.getNomeSoggettoFruitore()!=null){
  2075.                                 if(fruitore.getNome().equals(filtroFruizioni.getNomeSoggettoFruitore()) == false){
  2076.                                     continue;
  2077.                                 }
  2078.                             }
  2079.                             // ProtocolProperties
  2080.                             if(ProtocolPropertiesUtilities.isMatch(fruitore, filtroFruizioni.getProtocolPropertiesFruizione())==false){
  2081.                                 continue;
  2082.                             }
  2083.                             
  2084.                             IDFruizione idFruizione = new IDFruizione();
  2085.                             idFruizione.setIdServizio(idServ);
  2086.                             idFruizione.setIdFruitore(new IDSoggetto(fruitore.getTipo(), fruitore.getNome()));
  2087.                             listReturn.add((T)idFruizione);
  2088.                         }
  2089.                         
  2090.                         // Filtro By Tipo e/o Nome Soggetto Fruitore
  2091.                         if(filtroRicerca.getTipoSoggettoFruitore()!=null || filtroRicerca.getNomeSoggettoFruitore()!=null){
  2092.                             if(asps.sizeFruitoreList()<=0){
  2093.                                 continue;
  2094.                             }
  2095.                             boolean found = false;
  2096.                             for (int k = 0; k < asps.sizeFruitoreList(); k++) {
  2097.                                 Fruitore fruitore = asps.getFruitore(k);
  2098.                                 if(filtroRicerca.getTipoSoggettoFruitore()!=null){
  2099.                                     if(fruitore.getTipo().equals(filtroRicerca.getTipoSoggettoFruitore()) == false){
  2100.                                         continue;
  2101.                                     }
  2102.                                 }
  2103.                                 if(filtroRicerca.getNomeSoggettoFruitore()!=null){
  2104.                                     if(fruitore.getNome().equals(filtroRicerca.getNomeSoggettoFruitore()) == false){
  2105.                                         continue;
  2106.                                     }
  2107.                                 }
  2108.                                 found = true;
  2109.                                 break;
  2110.                             }
  2111.                             if(!found){
  2112.                                 continue;
  2113.                             }
  2114.                         }
  2115.                     }
  2116.                     else{
  2117.                         listReturn.add((T)idServ);
  2118.                     }
  2119.                 }
  2120.             }
  2121.             if(listReturn.size()<=0){
  2122.                 String msgFiltro = "Elementi non trovati che rispettano il filtro di ricerca selezionato: ";
  2123.                 if(filtroFruizioni!=null){
  2124.                     throw new DriverRegistroServiziNotFound(msgFiltro+filtroFruizioni.toString());
  2125.                 }
  2126.                 else if(filtroRicerca!=null){
  2127.                     throw new DriverRegistroServiziNotFound(msgFiltro+filtroRicerca.toString());
  2128.                 }
  2129.                 else
  2130.                     throw new DriverRegistroServiziNotFound("Elementi non trovati");
  2131.             }

  2133.         }catch(Exception e){
  2134.             throw new DriverRegistroServiziException(nomeMetodo+" error",e);
  2135.         }
  2136.     }

  2138.     @Override
  2139.     public Documento getAllegato(IDServizio idASPS, String nome) throws DriverRegistroServiziException,DriverRegistroServiziNotFound{
  2140.         org.openspcoop2.core.registry.AccordoServizioParteSpecifica asps = getAccordoServizioParteSpecifica(idASPS);
  2141.         if(asps.sizeAllegatoList()>0) {
  2142.             for (Documento doc : asps.getAllegatoList()) {
  2143.                 File f = new File(doc.getFile());
  2144.                 if(nome.equals(doc.getFile()) || nome.equals(f.getName())) {
  2145.                     return doc;
  2146.                 }
  2147.             }
  2148.         }
  2149.         throw new DriverRegistroServiziNotFound("Documento '"+nome+"' non trovato");
  2150.     }
  2151.     @Override
  2152.     public Documento getSpecificaSemiformale(IDServizio idASPS, TipiDocumentoSemiformale tipo, String nome)throws DriverRegistroServiziException,DriverRegistroServiziNotFound{
  2153.         org.openspcoop2.core.registry.AccordoServizioParteSpecifica asps = getAccordoServizioParteSpecifica(idASPS);
  2154.         if(asps.sizeSpecificaSemiformaleList()>0) {
  2155.             for (Documento doc : asps.getSpecificaSemiformaleList()) {
  2156.                 File f = new File(doc.getFile());
  2157.                 if(nome.equals(doc.getFile()) || nome.equals(f.getName())) {
  2158.                     if(tipo!=null && tipo.getNome().equals(doc.getTipo())) {
  2159.                         return doc;
  2160.                     }
  2161.                 }
  2162.             }
  2163.         }
  2164.         throw new DriverRegistroServiziNotFound("Documento '"+nome+"' non trovato");
  2165.     }
  2166.     
  2167.     @Override
  2168.     public Documento getSpecificaSicurezza(IDServizio idASPS, TipiDocumentoSicurezza tipo, String nome)throws DriverRegistroServiziException,DriverRegistroServiziNotFound{
  2169.         org.openspcoop2.core.registry.AccordoServizioParteSpecifica asps = getAccordoServizioParteSpecifica(idASPS);
  2170.         if(asps.sizeSpecificaSicurezzaList()>0) {
  2171.             for (Documento doc : asps.getSpecificaSicurezzaList()) {
  2172.                 File f = new File(doc.getFile());
  2173.                 if(nome.equals(doc.getFile()) || nome.equals(f.getName())) {
  2174.                     if(tipo!=null && tipo.getNome().equals(doc.getTipo())) {
  2175.                         return doc;
  2176.                     }
  2177.                 }
  2178.             }
  2179.         }
  2180.         throw new DriverRegistroServiziNotFound("Documento '"+nome+"' non trovato");
  2181.     }
  2182.     @Override
  2183.     public Documento getSpecificaLivelloServizio(IDServizio idASPS, TipiDocumentoLivelloServizio tipo, String nome)throws DriverRegistroServiziException,DriverRegistroServiziNotFound{
  2184.         org.openspcoop2.core.registry.AccordoServizioParteSpecifica asps = getAccordoServizioParteSpecifica(idASPS);
  2185.         if(asps.sizeSpecificaLivelloServizioList()>0) {
  2186.             for (Documento doc : asps.getSpecificaLivelloServizioList()) {
  2187.                 File f = new File(doc.getFile());
  2188.                 if(nome.equals(doc.getFile()) || nome.equals(f.getName())) {
  2189.                     if(tipo!=null && tipo.getNome().equals(doc.getTipo())) {
  2190.                         return doc;
  2191.                     }
  2192.                 }
  2193.             }
  2194.         }
  2195.         throw new DriverRegistroServiziNotFound("Documento '"+nome+"' non trovato");
  2196.     }
  2197.     



  2201.     /**
  2202.      * Metodo che verica la connessione ad una risorsa.
  2203.      * Se la connessione non e' presente, viene lanciata una eccezione che contiene il motivo della mancata connessione
  2204.      * 
  2205.      * @throws DriverException eccezione che contiene il motivo della mancata connessione
  2206.      */
  2207.     @Override
  2208.     public void isAlive() throws CoreException{
  2209.         
  2210.         if(this.create==false)
  2211.             throw new CoreException("Driver non inizializzato");
  2212.         
  2213.         try{
  2214.             this.forzaRefreshRegistroServiziXML();
  2215.         }catch(Exception e){
  2216.             throw new CoreException("Connessione al registro non disponibile: "+e.getMessage(),e);
  2217.         }
  2218.     }



  2222.     @Override
  2223.     public RegistroServizi getImmagineCompletaRegistroServizi() throws DriverRegistroServiziException{
  2224.         
  2225.         refreshRegistroServiziXML();        
  2226.         return this.registro;
  2227.     }
  2228. }
Created with JaCoCo 0.8.8.202204050719