ServiceIdentificationReader.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.registry;

  23. import org.openspcoop2.core.config.PortaApplicativa;
  24. import org.openspcoop2.core.config.PortaDelegata;
  25. import org.openspcoop2.core.id.IDPortaApplicativa;
  26. import org.openspcoop2.core.id.IDPortaDelegata;
  27. import org.openspcoop2.core.id.IDServizio;
  28. import org.openspcoop2.core.id.IDSoggetto;
  29. import org.openspcoop2.core.registry.driver.IDServizioFactory;
  30. import org.openspcoop2.protocol.sdk.IProtocolFactory;
  31. import org.openspcoop2.protocol.sdk.constants.CodiceErroreIntegrazione;
  32. import org.openspcoop2.protocol.sdk.constants.ErroreIntegrazione;
  33. import org.openspcoop2.protocol.sdk.constants.ErroriIntegrazione;
  34. import org.openspcoop2.protocol.sdk.registry.IConfigIntegrationReader;
  35. import org.openspcoop2.protocol.sdk.registry.IRegistryReader;
  36. import org.openspcoop2.protocol.sdk.registry.IServiceIdentificationReader;
  37. import org.openspcoop2.protocol.sdk.registry.RegistryNotFound;
  38. import org.openspcoop2.utils.transport.TransportRequestContext;
  39. import org.slf4j.Logger;

  41. /**
  42.  *  ArchiveRegistryReader
  43.  *
  44.  * @author Poli Andrea (apoli@link.it)
  45.  * @author $Author$
  46.  * @version $Rev$, $Date$
  47.  */
  48. public class ServiceIdentificationReader implements IServiceIdentificationReader {

  50.     private IRegistryReader registryReader;
  51.     private IConfigIntegrationReader configIntegrationReader;
  52.     private IProtocolFactory<?> protocolFactory;
  53.     private Logger log;
  54.     public ServiceIdentificationReader(IRegistryReader registryReader, IConfigIntegrationReader configIntegrationReader,
  55.             IProtocolFactory<?> protocolFactory, Logger log) {
  56.         this.registryReader = registryReader;
  57.         this.configIntegrationReader = configIntegrationReader;
  58.         this.protocolFactory = protocolFactory;
  59.         this.log = log;
  60.     }
  61.     
  62.     private ErroreIntegrazione erroreIntegrazioneNotFound;
  63.     
  64.     public ErroreIntegrazione getErroreIntegrazioneNotFound() {
  65.         return this.erroreIntegrazioneNotFound;
  66.     }
  67.     
  68.     public IRegistryReader getRegistryReader() {
  69.         return this.registryReader;
  70.     }

  72.     public IConfigIntegrationReader getConfigIntegrationReader() {
  73.         return this.configIntegrationReader;
  74.     }
  75.     
  76.     
  77.     // PORTA DELEGATA
  78.     
  79.     private PortaDelegata pd;
  80.     private IDPortaDelegata idPD;
  81.     
  82.     @Override
  83.     public IDPortaDelegata findPortaDelegata(TransportRequestContext transportRequestContext, boolean portaUrlBased) throws RegistryNotFound{
  84.             
  85.         IdentificazionePortaDelegata idPD = null;
  86.         try{
  87.         
  88.             idPD = new IdentificazionePortaDelegata(transportRequestContext, this.log, portaUrlBased, 
  89.                     this.registryReader, this.configIntegrationReader, this.protocolFactory);
  90.             if(idPD.process()==false){
  91.                 if(CodiceErroreIntegrazione.CODICE_401_PORTA_INESISTENTE.equals(idPD.getCodiceErrore())){
  92.                     throw new RegistryNotFound(idPD.getMessaggioErrore());
  93.                 }
  94.                 else {
  95.                     throw new Exception(idPD.getMessaggioErrore());
  96.                 }
  97.             }
  98.             this.pd = idPD.getPortaDelegata();
  99.             this.idPD = idPD.getIDPortaDelegata();
  100.             
  101.             if(this.idPD.getIdentificativiFruizione()!=null){
  102.                 if(this.idPD.getIdentificativiFruizione().getIdServizio()!=null){
  103.                     if(this.idPD.getIdentificativiFruizione().getIdServizio().getSoggettoErogatore()!=null){
  104.                         if(this.idPD.getIdentificativiFruizione().getIdServizio().getSoggettoErogatore().getCodicePorta()==null){
  105.                             this.idPD.getIdentificativiFruizione().getIdServizio().getSoggettoErogatore().setCodicePorta(
  106.                                     this.registryReader.getDominio(this.idPD.getIdentificativiFruizione().getIdServizio().getSoggettoErogatore()));
  107.                         }
  108.                     }
  109.                 }
  110.                 if(this.idPD.getIdentificativiFruizione().getSoggettoFruitore()!=null){
  111.                     if(this.idPD.getIdentificativiFruizione().getSoggettoFruitore().getCodicePorta()==null){
  112.                         this.idPD.getIdentificativiFruizione().getSoggettoFruitore().setCodicePorta(
  113.                                 this.registryReader.getDominio(this.idPD.getIdentificativiFruizione().getSoggettoFruitore()));
  114.                     }
  115.                 }
  116.             }
  117.             
  118.             return this.idPD;
  119.             
  120.         }
  121.         catch(RegistryNotFound e){
  122.             this.erroreIntegrazioneNotFound = idPD.getErroreIntegrazione();
  123.             throw e;
  124.         }
  125.         catch(Exception e){
  126.             this.log.error("findPortaDelegata error: "+e.getMessage(),e);
  127.             return null;
  128.         }

  130.     }
  131.     
  132.     @Override
  133.     public IDSoggetto convertToIDSoggettoFruitore(IDPortaDelegata idPortaDelegata) throws RegistryNotFound{
  134.         
  135.         try{
  136.             if(this.idPD!=null && this.idPD.getIdentificativiFruizione()!=null &&
  137.                     this.idPD.getIdentificativiFruizione().getSoggettoFruitore()!=null){
  138.                 return this.idPD.getIdentificativiFruizione().getSoggettoFruitore();
  139.             }
  140.             
  141.             if(this.pd==null){
  142.                 this.pd = this.configIntegrationReader.getPortaDelegata(idPortaDelegata);
  143.             }
  144.             IDSoggetto idS = new IDSoggetto(this.pd.getTipoSoggettoProprietario(), this.pd.getNomeSoggettoProprietario());
  145.             if(idS.getCodicePorta()==null){
  146.                 idS.setCodicePorta(this.registryReader.getDominio(idS));
  147.             }
  148.             
  149.             return idS;
  150.         }
  151.         catch(RegistryNotFound e){
  152.             this.erroreIntegrazioneNotFound = 
  153.                     ErroriIntegrazione.ERRORE_401_PORTA_INESISTENTE.
  154.                     getErrore401_PortaInesistente(e.getMessage(),idPortaDelegata.getNome(),idPortaDelegata.getNome());
  155.             throw e;
  156.         }
  157.         catch(Exception e){
  158.             return null;
  159.         }
  160.         
  161.     }
  162.     
  163.     @Override
  164.     public IDServizio convertToIDServizio(IDPortaDelegata idPortaDelegata) throws RegistryNotFound{
  165.         
  166.         try{
  167.             if(this.idPD!=null && this.idPD.getIdentificativiFruizione()!=null &&
  168.                     this.idPD.getIdentificativiFruizione().getIdServizio()!=null){
  169.                 return this.idPD.getIdentificativiFruizione().getIdServizio();
  170.             }
  171.             
  172.             if(this.pd==null){
  173.                 this.pd = this.configIntegrationReader.getPortaDelegata(idPortaDelegata);
  174.             }
  175.             IDServizio idS = IDServizioFactory.getInstance().getIDServizioFromValues(this.pd.getServizio().getTipo(), this.pd.getServizio().getNome(), 
  176.                     new IDSoggetto(this.pd.getSoggettoErogatore().getTipo(), this.pd.getSoggettoErogatore().getNome()), 
  177.                     this.pd.getServizio().getVersione());           
  178.             if(idS.getSoggettoErogatore().getCodicePorta()==null){
  179.                 idS.getSoggettoErogatore().setCodicePorta(this.registryReader.getDominio(idS.getSoggettoErogatore()));
  180.             }
  181.             
  182.             return idS;
  183.         }
  184.         catch(RegistryNotFound e){
  185.             this.erroreIntegrazioneNotFound = 
  186.                     ErroriIntegrazione.ERRORE_401_PORTA_INESISTENTE.
  187.                     getErrore401_PortaInesistente(e.getMessage(),idPortaDelegata.getNome(),idPortaDelegata.getNome());
  188.             throw e;
  189.         }
  190.         catch(Exception e){
  191.             return null;
  192.         }
  193.         
  194.     }
  195.     
  196.     
  197.     // PORTA APPLICATIVA
  198.     
  199.     private PortaApplicativa pa;
  200.     private IDPortaApplicativa idPA;
  201.     
  202.     @Override
  203.     public IDPortaApplicativa findPortaApplicativa(TransportRequestContext transportRequestContext, boolean portaUrlBased) throws RegistryNotFound{
  204.         
  205.         IdentificazionePortaApplicativa idPA = null;
  206.         try{
  207.             
  208.             idPA = new IdentificazionePortaApplicativa(transportRequestContext, this.log, portaUrlBased, 
  209.                     this.registryReader, this.configIntegrationReader, this.protocolFactory);
  210.             if(idPA.process()==false){
  211.                 if(CodiceErroreIntegrazione.CODICE_401_PORTA_INESISTENTE.equals(idPA.getCodiceErrore())){
  212.                     throw new RegistryNotFound(idPA.getMessaggioErrore());
  213.                 }
  214.                 else {
  215.                     throw new Exception(idPA.getMessaggioErrore());
  216.                 }
  217.             }
  218.             this.pa = idPA.getPortaApplicativa();
  219.             this.idPA = idPA.getIDPortaApplicativa();
  220.             
  221.             if(this.idPA.getIdentificativiErogazione()!=null){
  222.                 if(this.idPA.getIdentificativiErogazione().getSoggettoVirtuale()!=null){
  223.                     if(this.idPA.getIdentificativiErogazione().getSoggettoVirtuale().getCodicePorta()==null){
  224.                         this.idPA.getIdentificativiErogazione().getSoggettoVirtuale().setCodicePorta(this.registryReader.getDominio(this.idPA.getIdentificativiErogazione().getSoggettoVirtuale()));
  225.                     }
  226.                 }
  227.                 if(this.idPA.getIdentificativiErogazione().getIdServizio()!=null){
  228.                     if(this.idPA.getIdentificativiErogazione().getIdServizio().getSoggettoErogatore()!=null){
  229.                         if(this.idPA.getIdentificativiErogazione().getIdServizio().getSoggettoErogatore().getCodicePorta()==null){
  230.                             this.idPA.getIdentificativiErogazione().getIdServizio().getSoggettoErogatore().setCodicePorta(
  231.                                     this.registryReader.getDominio(this.idPA.getIdentificativiErogazione().getIdServizio().getSoggettoErogatore()));
  232.                         }
  233.                     }
  234.                 }
  235.             }
  236.             
  237.             return this.idPA;
  238.             
  239.         }
  240.         catch(RegistryNotFound e){
  241.             this.erroreIntegrazioneNotFound = idPA.getErroreIntegrazione();
  242.             throw e;
  243.         }
  244.         catch(Exception e){
  245.             this.log.error("findPortaDelegata error: "+e.getMessage(),e);
  246.             return null;
  247.         }
  248.         
  249.     }
  250.     
  251.     @Override
  252.     public IDServizio convertToIDServizio(IDPortaApplicativa idPortaApplicativa) throws RegistryNotFound{
  253.         
  254.         try{
  255.             if(this.idPA!=null && this.idPA.getIdentificativiErogazione()!=null &&
  256.                     this.idPA.getIdentificativiErogazione().getIdServizio()!=null){
  257.                 return this.idPA.getIdentificativiErogazione().getIdServizio();
  258.             }
  259.             
  260.             if(this.pa==null){
  261.                 this.pa = this.configIntegrationReader.getPortaApplicativa(idPortaApplicativa);
  262.             }
  263.             IDServizio idS = IDServizioFactory.getInstance().getIDServizioFromValues(this.pa.getServizio().getTipo(), this.pa.getServizio().getNome(), 
  264.                     new IDSoggetto(this.pa.getTipoSoggettoProprietario(),this.pa.getNomeSoggettoProprietario()), 
  265.                     this.pa.getServizio().getVersione());       
  266.             
  267.             if(idS.getSoggettoErogatore().getCodicePorta()==null){
  268.                 idS.getSoggettoErogatore().setCodicePorta(this.registryReader.getDominio(idS.getSoggettoErogatore()));
  269.             }
  270.             
  271.             return idS;
  272.         }
  273.         catch(RegistryNotFound e){
  274.             this.erroreIntegrazioneNotFound = 
  275.                     ErroriIntegrazione.ERRORE_401_PORTA_INESISTENTE.
  276.                     getErrore401_PortaInesistente(e.getMessage(),idPortaApplicativa.getNome(),idPortaApplicativa.getNome());
  277.             throw e;
  278.         }
  279.         catch(Exception e){
  280.             return null;
  281.         }
  282.         
  283.     } 
  284. }
Created with JaCoCo 0.8.8.202204050719