AbstractConverter.java

  1. /*
  2.  * GovWay - A customizable API Gateway 
  3.  * https://govway.org
  4.  * 
  5.  * Copyright (c) 2005-2025 Link.it srl (https://link.it). 
  6.  * 
  7.  * This program is free software: you can redistribute it and/or modify
  8.  * it under the terms of the GNU General Public License version 3, as published by
  9.  * the Free Software Foundation.
  10.  *
  11.  * This program is distributed in the hope that it will be useful,
  12.  * but WITHOUT ANY WARRANTY; without even the implied warranty of
  13.  * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
  14.  * GNU General Public License for more details.
  15.  *
  16.  * You should have received a copy of the GNU General Public License
  17.  * along with this program.  If not, see <http://www.gnu.org/licenses/>.
  18.  *
  19.  */

  21. package org.openspcoop2.protocol.basic.archive.abstraction;

  23. import java.util.ArrayList;
  24. import java.util.List;

  26. import org.openspcoop2.core.config.ServizioApplicativo;
  27. import org.openspcoop2.core.id.IDAccordo;
  28. import org.openspcoop2.core.id.IDServizio;
  29. import org.openspcoop2.core.id.IDServizioApplicativo;
  30. import org.openspcoop2.core.id.IDSoggetto;
  31. import org.openspcoop2.core.registry.AccordoServizioParteSpecifica;
  32. import org.openspcoop2.core.registry.driver.DriverRegistroServiziException;
  33. import org.openspcoop2.core.registry.driver.IDAccordoFactory;
  34. import org.openspcoop2.core.registry.driver.IDServizioFactory;
  35. import org.openspcoop2.protocol.abstraction.Soggetto;
  36. import org.openspcoop2.protocol.basic.archive.ZIPReadUtils;
  37. import org.openspcoop2.protocol.sdk.ProtocolException;
  38. import org.openspcoop2.protocol.sdk.archive.Archive;
  39. import org.openspcoop2.protocol.sdk.registry.ProtocolFiltroRicercaAccordi;
  40. import org.openspcoop2.protocol.sdk.registry.ProtocolFiltroRicercaServizi;
  41. import org.openspcoop2.protocol.sdk.registry.IConfigIntegrationReader;
  42. import org.openspcoop2.protocol.sdk.registry.IRegistryReader;
  43. import org.openspcoop2.protocol.sdk.registry.RegistryException;
  44. import org.openspcoop2.protocol.sdk.registry.RegistryNotFound;
  45. import org.slf4j.Logger;

  47. /**     
  48.  * AbstractConverter
  49.  *
  50.  * @author Poli Andrea (poli@link.it)
  51.  * @author $Author$
  52.  * @version $Rev$, $Date$
  53.  */
  54. public abstract class AbstractConverter {


  57.     
  58.     protected IDAccordoFactory idAccordoFactory;
  59.     protected IDServizioFactory idServizioFactory;
  60.     protected Logger log;
  61.     protected ZIPReadUtils filler;
  62.     
  63.     protected AbstractConverter(Logger log,ZIPReadUtils zipReader) throws ProtocolException{
  64.         this.idAccordoFactory = IDAccordoFactory.getInstance();
  65.         this.idServizioFactory = IDServizioFactory.getInstance();
  66.         this.log = log;
  67.         this.filler = zipReader;
  68.     }
  69.             
  70.     protected boolean existsPdd(Archive archive, IRegistryReader registryReader, String pdd) {
  71.         
  72.         // Cerco nel registro
  73.         if(registryReader.existsPortaDominio(pdd)){
  74.             return true;
  75.         }
  76.                 
  77.         // Cerco negli oggetti presenti nell'archivio
  78.         if(archive.getPdd().size()>0){
  79.             for (int i = 0; i < archive.getPdd().size(); i++) {
  80.                 String nome = archive.getPdd().get(i).getPortaDominio().getNome();
  81.                 if(nome.equals(pdd)){
  82.                     return true;
  83.                 }
  84.             }
  85.         }
  86.         
  87.         return false;
  88.                 
  89.     }
  90.     
  91.     protected boolean isPddOperativa(Archive archive, IRegistryReader registryReader, String pdd) throws RegistryException{
  92.         
  93.         // Cerco nel registro
  94.         if(registryReader.existsPortaDominio(pdd)){
  95.             try{
  96.                 if(registryReader.findIdPorteDominio(true).contains(pdd)){
  97.                     return true;
  98.                 }
  99.             }catch(RegistryNotFound notFound){
  100.                 return false;
  101.             }
  102.         }
  103.         
  104.         return false; // le pdd presenti nell'archivio vengono aggiunte come esterne.
  105.     }
  106.     
  107.     protected String getPddOperativa(IRegistryReader registryReader) throws RegistryNotFound, RegistryException{
  108.         return registryReader.findIdPorteDominio(true).get(0); // una pdd operativa esiste sempre
  109.     }
  110.     
  111.     protected boolean existsSoggetto(Archive archive, IRegistryReader registryReader, Soggetto idSoggetto) {
  112.         
  113.         // Cerco nel registro
  114.         if(registryReader.existsSoggetto(new IDSoggetto(idSoggetto.getTipo(), idSoggetto.getNome()))){
  115.             return true;
  116.         }
  117.         
  118.         // Cerco negli oggetti presenti nell'archivio
  119.         if(archive.getSoggetti().size()>0){
  120.             for (int i = 0; i < archive.getSoggetti().size(); i++) {
  121.                 org.openspcoop2.core.registry.Soggetto soggetto = archive.getSoggetti().get(i).getSoggettoRegistro();
  122.                 if(soggetto!=null){
  123.                     if(idSoggetto.getTipo().equals(soggetto.getTipo()) && idSoggetto.getNome().equals(soggetto.getNome())){
  124.                         return true;
  125.                     }
  126.                 }
  127.             }
  128.         }
  129.         
  130.         return false;
  131.                 
  132.     }
  133.     
  134.     protected boolean existsServizioApplicativo(Archive archive, IConfigIntegrationReader configIntegrationReader, Soggetto idSoggetto, String nomeServizioApplicativo) {
  135.         
  136.         IDServizioApplicativo idServizioApplicativo = new IDServizioApplicativo();
  137.         idServizioApplicativo.setIdSoggettoProprietario(new IDSoggetto(idSoggetto.getTipo(), idSoggetto.getNome()));
  138.         idServizioApplicativo.setNome(nomeServizioApplicativo);
  139.         
  140.         // Cerco nel registro
  141.         if(configIntegrationReader.existsServizioApplicativo(idServizioApplicativo)){
  142.             return true;
  143.         }
  144.         
  145.         // Cerco negli oggetti presenti nell'archivio
  146.         if(archive.getServiziApplicativi().size()>0){
  147.             for (int i = 0; i < archive.getServiziApplicativi().size(); i++) {
  148.                 org.openspcoop2.core.config.ServizioApplicativo sa = archive.getServiziApplicativi().get(i).getServizioApplicativo();
  149.                 if(sa!=null){
  150.                     if(idSoggetto.getTipo().equals(sa.getTipoSoggettoProprietario()) && 
  151.                             idSoggetto.getNome().equals(sa.getNomeSoggettoProprietario()) &&
  152.                             nomeServizioApplicativo.equals(sa.getNome())){
  153.                         return true;
  154.                     }
  155.                 }
  156.             }
  157.         }
  158.         
  159.         return false;
  160.                 
  161.     }
  162.     
  163.     protected String getTipoCredenzialeServizioApplicativo(Archive archive, IConfigIntegrationReader configIntegrationReader, Soggetto idSoggetto, String nomeServizioApplicativo) throws Exception {
  164.         
  165.         IDServizioApplicativo idServizioApplicativo = new IDServizioApplicativo();
  166.         idServizioApplicativo.setIdSoggettoProprietario(new IDSoggetto(idSoggetto.getTipo(), idSoggetto.getNome()));
  167.         idServizioApplicativo.setNome(nomeServizioApplicativo);
  168.         
  169.         ServizioApplicativo sa = null;
  170.         
  171.         // Cerco nel registro
  172.         if(configIntegrationReader.existsServizioApplicativo(idServizioApplicativo)){
  173.             sa = configIntegrationReader.getServizioApplicativo(idServizioApplicativo);
  174.         }
  175.         else{
  176.             // Cerco negli oggetti presenti nell'archivio
  177.             if(archive.getServiziApplicativi().size()>0){
  178.                 for (int i = 0; i < archive.getServiziApplicativi().size(); i++) {
  179.                     org.openspcoop2.core.config.ServizioApplicativo saTmp = archive.getServiziApplicativi().get(i).getServizioApplicativo();
  180.                     if(saTmp!=null){
  181.                         if(idSoggetto.getTipo().equals(saTmp.getTipoSoggettoProprietario()) && 
  182.                                 idSoggetto.getNome().equals(saTmp.getNomeSoggettoProprietario()) &&
  183.                                 nomeServizioApplicativo.equals(saTmp.getNome())){
  184.                             sa = saTmp;
  185.                             break;
  186.                         }
  187.                     }
  188.                 }
  189.             }
  190.         }
  191.         
  192.         if(sa==null){
  193.             throw new Exception("Servizio Applicativo ["+idServizioApplicativo.toString()+"] non esistente");
  194.         }
  195.         if(sa.getInvocazionePorta()==null){
  196.             throw new Exception("Servizio Applicativo ["+idServizioApplicativo.toString()+"] non possiede delle credenziali di accesso alla PdD (Indicare un applicativo con tipologia 'fruitore')");
  197.         }
  198.         if(sa.getInvocazionePorta().sizeCredenzialiList()<=0){
  199.             throw new Exception("Servizio Applicativo ["+idServizioApplicativo.toString()+"] non possiede delle credenziali di accesso alla PdD (Indicare un applicativo con tipologia 'fruitore') con credenziali");
  200.         }
  201.         return sa.getInvocazionePorta().getCredenziali(0).getTipo().getValue();
  202.                 
  203.     }
  204.     
  205.     protected boolean existsAccordoServizioParteComune(Archive archive, IRegistryReader registryReader, IDAccordo idAccordo) throws RegistryException {
  206.         
  207.         // Cerco nel registro
  208.         try{
  209.             registryReader.getAccordoServizioParteComune(idAccordo);
  210.             return true;
  211.         }catch(RegistryNotFound notFound){
  212.             // ignore
  213.         }
  214.         
  215.         // Cerco negli oggetti presenti nell'archivio
  216.         if(archive.getAccordiServizioParteComune().size()>0){
  217.             for (int i = 0; i < archive.getAccordiServizioParteComune().size(); i++) {
  218.                 try{
  219.                     IDAccordo id = this.idAccordoFactory.getIDAccordoFromAccordo(archive.getAccordiServizioParteComune().get(i).getAccordoServizioParteComune());
  220.                     if(idAccordo.equals(id)){
  221.                         return true;
  222.                     }
  223.                 }catch(Exception e){
  224.                     // ignore
  225.                 }
  226.             }
  227.         }
  228.         if(archive.getAccordiServizioComposto().size()>0){
  229.             for (int i = 0; i < archive.getAccordiServizioComposto().size(); i++) {
  230.                 try{
  231.                     IDAccordo id = this.idAccordoFactory.getIDAccordoFromAccordo(archive.getAccordiServizioComposto().get(i).getAccordoServizioParteComune());
  232.                     if(idAccordo.equals(id)){
  233.                         return true;
  234.                     }
  235.                 }catch(Exception e){
  236.                     // ignore
  237.                 }
  238.             }
  239.         }

  241.         return false;
  242.                 
  243.     }
  244.     
  245.     protected IDAccordo findIdAccordoServizioParteComune(Archive archive, IRegistryReader registryReader, 
  246.             String nome, Soggetto idSoggetto, Integer versione) throws DriverRegistroServiziException, ProtocolException, RegistryException{
  247.         
  248.         List<IDAccordo> idAccordi = new ArrayList<IDAccordo>();
  249.         List<String> uriAccordi = new ArrayList<>();
  250.         
  251.         // Cerco nel registro
  252.         ProtocolFiltroRicercaAccordi filtroAccordi = new ProtocolFiltroRicercaAccordi();
  253.         filtroAccordi.setNome(nome);
  254.         if(versione!=null){
  255.             filtroAccordi.setVersione(versione);
  256.         }
  257.         if(idSoggetto!=null){
  258.             IDSoggetto idSoggettoOp2 = new IDSoggetto(idSoggetto.getTipo(), idSoggetto.getNome());
  259.             filtroAccordi.setSoggetto(idSoggettoOp2);
  260.         }
  261.         try {
  262.             List<IDAccordo> found = registryReader.findIdAccordiServizioParteComune(filtroAccordi);
  263.             if(found.size()>0){
  264.                 for (IDAccordo id : found) {
  265.                     idAccordi.add(id);
  266.                     uriAccordi.add(this.idAccordoFactory.getUriFromIDAccordo(id));
  267.                 }
  268.             }
  269.         } catch (RegistryNotFound e) {
  270.         }
  271.         
  272.         // Cerco negli oggetti presenti nell'archivio
  273.         if(archive.getAccordiServizioParteComune().size()>0){
  274.             for (int i = 0; i < archive.getAccordiServizioParteComune().size(); i++) {
  275.                 try{    
  276.                     IDAccordo id = this.idAccordoFactory.getIDAccordoFromAccordo(archive.getAccordiServizioParteComune().get(i).getAccordoServizioParteComune());
  277.                     if(nome.equals(id.getNome())==false){
  278.                         continue;
  279.                     }
  280.                     if(versione!=null && id.getVersione()!=null && (versione.intValue()!=id.getVersione().intValue()) ){
  281.                         continue;
  282.                     }
  283.                     if(idSoggetto!=null){
  284.                         if(id.getSoggettoReferente()==null){
  285.                             continue;
  286.                         }
  287.                         if(idSoggetto.getTipo()!=null && idSoggetto.getTipo().equals(id.getSoggettoReferente().getTipo())==false){
  288.                             continue;
  289.                         }
  290.                         if(idSoggetto.getNome()!=null && idSoggetto.getNome().equals(id.getSoggettoReferente().getNome())==false){
  291.                             continue;
  292.                         }
  293.                     }
  294.                     String uri = this.idAccordoFactory.getUriFromIDAccordo(id);
  295.                     if(uriAccordi.contains(uri)==false){
  296.                         idAccordi.add(id);
  297.                         uriAccordi.add(uri);
  298.                     }
  299.                 }catch(Exception e){
  300.                     // ignore
  301.                 }
  302.             }
  303.         }
  304.         if(archive.getAccordiServizioComposto().size()>0){
  305.             for (int i = 0; i < archive.getAccordiServizioComposto().size(); i++) {
  306.                 try{
  307.                     IDAccordo id = this.idAccordoFactory.getIDAccordoFromAccordo(archive.getAccordiServizioComposto().get(i).getAccordoServizioParteComune());
  308.                     if(nome.equals(id.getNome())==false){
  309.                         continue;
  310.                     }
  311.                     if(versione!=null && id.getVersione()!=null && (versione.intValue()!=id.getVersione().intValue()) ){
  312.                         continue;
  313.                     }
  314.                     if(idSoggetto!=null){
  315.                         if(id.getSoggettoReferente()==null){
  316.                             continue;
  317.                         }
  318.                         if(idSoggetto.getTipo()!=null && idSoggetto.getTipo().equals(id.getSoggettoReferente().getTipo())==false){
  319.                             continue;
  320.                         }
  321.                         if(idSoggetto.getNome()!=null && idSoggetto.getNome().equals(id.getSoggettoReferente().getNome())==false){
  322.                             continue;
  323.                         }
  324.                     }
  325.                     String uri = this.idAccordoFactory.getUriFromIDAccordo(id);
  326.                     if(uriAccordi.contains(uri)==false){
  327.                         idAccordi.add(id);
  328.                         uriAccordi.add(uri);
  329.                     }
  330.                 }catch(Exception e){
  331.                     // ignore
  332.                 }
  333.             }
  334.         }
  335.         
  336.         // Verifico
  337.         if(idAccordi.size()==1){
  338.             return idAccordi.get(0);
  339.         }
  340.         else {
  341.             String filtro = "Nome["+nome+"]";
  342.             if(versione!=null){
  343.                 filtro = filtro + " Versione["+versione+"]";
  344.             }
  345.             if(idSoggetto!=null){
  346.                 filtro = filtro + " TipoSoggetto["+idSoggetto.getTipo()+"]";
  347.                 filtro = filtro + " NomeSoggetto["+idSoggetto.getNome()+"]";
  348.             }
  349.             if(idAccordi.size()<1){
  350.                 throw new ProtocolException("Non risultano accordi di servizio parte comune che corrispondono al seguente criterio di ricerca: "+filtro);
  351.             }
  352.             else{
  353.                 throw new ProtocolException("Risultano più accordi di servizio parte comune ("+uriAccordi.size()+") che corrispondono al seguente criterio di ricerca: "+filtro+""
  354.                         + "\nGli accordi sono: "+uriAccordi.toString());
  355.             }
  356.         }
  357.     }
  358.     
  359.     
  360.     protected boolean existsAccordoServizioParteSpecifica(Archive archive, IRegistryReader registryReader, IDServizio idServizio) throws RegistryException {
  361.         
  362.         // Cerco nel registro
  363.         try{
  364.             registryReader.getAccordoServizioParteSpecifica(idServizio);
  365.             return true;
  366.         }catch(RegistryNotFound notFound){
  367.             // ignore
  368.         }
  369.         
  370.         // Cerco negli oggetti presenti nell'archivio
  371.         if(archive.getAccordiServizioParteSpecifica().size()>0){
  372.             for (int i = 0; i < archive.getAccordiServizioParteSpecifica().size(); i++) {
  373.                 try{
  374.                     AccordoServizioParteSpecifica asps = archive.getAccordiServizioParteSpecifica().get(i).getAccordoServizioParteSpecifica();
  375.                     IDServizio id = IDServizioFactory.getInstance().getIDServizioFromValues(asps.getTipo(), asps.getNome(),
  376.                             asps.getTipoSoggettoErogatore(), asps.getNomeSoggettoErogatore(), 
  377.                             asps.getVersione()); 
  378.                     if(idServizio.equals(id)){
  379.                         return true;
  380.                     }
  381.                 }catch(Exception e){
  382.                     // ignore
  383.                 }
  384.             }
  385.         }

  387.         return false;
  388.                 
  389.     }

  391.     
  392.     protected AccordoServizioParteSpecifica getAccordoServizioParteSpecifica(Archive archive, IRegistryReader registryReader, IDServizio idServizio) throws RegistryException {
  393.     
  394.         // Cerco nel registro
  395.         try{
  396.             return registryReader.getAccordoServizioParteSpecifica(idServizio);
  397.         }catch(RegistryNotFound notFound){
  398.             // ignore
  399.         }
  400.         
  401.         // Cerco negli oggetti presenti nell'archivio
  402.         if(archive.getAccordiServizioParteSpecifica().size()>0){
  403.             for (int i = 0; i < archive.getAccordiServizioParteSpecifica().size(); i++) {
  404.                 try{
  405.                     AccordoServizioParteSpecifica asps = archive.getAccordiServizioParteSpecifica().get(i).getAccordoServizioParteSpecifica();
  406.                     if(idServizio.getTipo().equals(asps.getTipo())==false ){
  407.                         continue;
  408.                     }
  409.                     if(idServizio.getNome().equals(asps.getNome())==false){
  410.                         continue;
  411.                     }
  412.                     if(idServizio.getVersione().intValue() != asps.getVersione().intValue()){
  413.                         continue;
  414.                     }
  415.                     if(idServizio.getSoggettoErogatore().getTipo().equals(asps.getTipoSoggettoErogatore())==false){
  416.                         continue;
  417.                     }
  418.                     if(idServizio.getSoggettoErogatore().getNome().equals(asps.getNomeSoggettoErogatore())==false){
  419.                         continue;
  420.                     }
  421.                     return asps;
  422.                 }catch(Exception e){
  423.                     // ignore
  424.                 }
  425.             }
  426.         }
  427.         return null;
  428.                 
  429.     }
  430.     
  431.     protected IDServizio findIdAccordoServizioParteSpecifica(Archive archive, IRegistryReader registryReader, 
  432.             String nome, String tipo, Integer versione, Soggetto idSoggetto) throws DriverRegistroServiziException, ProtocolException, RegistryException{
  433.         
  434.         List<IDServizio> idAccordi = new ArrayList<IDServizio>();
  435.         List<String> uriAccordi = new ArrayList<>();
  436.         
  437.         // Cerco nel registro
  438.         ProtocolFiltroRicercaServizi filtroAccordi = new ProtocolFiltroRicercaServizi();
  439.         filtroAccordi.setTipoServizio(tipo);
  440.         filtroAccordi.setNomeServizio(nome);
  441.         if(idSoggetto!=null){
  442.             IDSoggetto idSoggettoOp2 = new IDSoggetto(idSoggetto.getTipo(), idSoggetto.getNome());
  443.             filtroAccordi.setSoggettoErogatore(idSoggettoOp2);
  444.         }
  445.         try {
  446.             List<IDServizio> found = registryReader.findIdAccordiServizioParteSpecifica(filtroAccordi);
  447.             if(found.size()>0){
  448.                 for (IDServizio id : found) {
  449.                     idAccordi.add(id);
  450.                     uriAccordi.add(id.toString());
  451.                 }
  452.             }
  453.         } catch (RegistryNotFound e) {
  454.         }
  455.         
  456.         // Cerco negli oggetti presenti nell'archivio
  457.         if(archive.getAccordiServizioParteSpecifica().size()>0){
  458.             for (int i = 0; i < archive.getAccordiServizioParteSpecifica().size(); i++) {
  459.                 try{
  460.                     AccordoServizioParteSpecifica asps = archive.getAccordiServizioParteSpecifica().get(i).getAccordoServizioParteSpecifica();
  461.                     if(tipo!=null && (tipo.equals(asps.getTipo())==false) ){
  462.                         continue;
  463.                     }
  464.                     if(nome.equals(asps.getNome())==false){
  465.                         continue;
  466.                     }
  467.                     if(versione!=null && (versione.intValue() != asps.getVersione().intValue()) ){
  468.                         continue;
  469.                     }
  470.                     if(idSoggetto!=null){
  471.                         if(idSoggetto.getTipo().equals(asps.getTipoSoggettoErogatore())==false){
  472.                             continue;
  473.                         }
  474.                         if(idSoggetto.getNome().equals(asps.getNomeSoggettoErogatore())==false){
  475.                             continue;
  476.                         }

  478.                         IDServizio idServizio = IDServizioFactory.getInstance().getIDServizioFromValues(tipo, nome,
  479.                                 new IDSoggetto(idSoggetto.getTipo(),idSoggetto.getNome()), 
  480.                                 versione);
  481.                         String uri = idServizio.toString();
  482.                         if(uriAccordi.contains(uri)==false){
  483.                             idAccordi.add(idServizio);
  484.                             uriAccordi.add(uri);
  485.                         }
  486.                     }
  487.                 }catch(Exception e){
  488.                     // ignore
  489.                 }
  490.             }
  491.         }
  492.         
  493.         
  494.         // Verifico
  495.         if(idAccordi.size()==1){
  496.             return idAccordi.get(0);
  497.         }
  498.         else {
  499.             String filtro = "Nome["+nome+"]";
  500.             if(tipo!=null){
  501.                 filtro = filtro + " Tipo["+tipo+"]";
  502.             }
  503.             if(idSoggetto!=null){
  504.                 filtro = filtro + " TipoSoggetto["+idSoggetto.getTipo()+"]";
  505.                 filtro = filtro + " NomeSoggetto["+idSoggetto.getNome()+"]";
  506.             }
  507.             if(idAccordi.size()<1){
  508.                 throw new ProtocolException("Non risultano accordi di servizio parte specifica che corrispondono al seguente criterio di ricerca: "+filtro);
  509.             }
  510.             else{
  511.                 throw new ProtocolException("Risultano più accordi di servizio parte specifica ("+uriAccordi.size()+") che corrispondono al seguente criterio di ricerca: "+filtro+""
  512.                         + "\nGli accordi sono: "+uriAccordi.toString());
  513.             }
  514.         }
  515.     }
  516.         
  517.     
  518. }
Created with JaCoCo 0.8.8.202204050719