GestioneToken.java

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



  23. package org.openspcoop2.pdd.core.token.pd;

  25. import org.openspcoop2.core.id.IDServizio;
  26. import org.openspcoop2.core.id.IDSoggetto;
  27. import org.openspcoop2.core.registry.driver.DriverRegistroServiziException;
  28. import org.openspcoop2.core.registry.driver.IDServizioFactory;
  29. import org.openspcoop2.pdd.core.PdDContext;
  30. import org.openspcoop2.pdd.core.token.EsitoDynamicDiscovery;
  31. import org.openspcoop2.pdd.core.token.EsitoGestioneToken;
  32. import org.openspcoop2.pdd.core.token.EsitoPresenzaToken;
  33. import org.openspcoop2.pdd.core.token.GestoreToken;
  34. import org.openspcoop2.pdd.core.token.InformazioniToken;
  35. import org.openspcoop2.pdd.core.token.TokenException;
  36. import org.openspcoop2.protocol.sdk.Busta;
  37. import org.openspcoop2.protocol.sdk.IProtocolFactory;
  38. import org.openspcoop2.protocol.sdk.constants.CodiceErroreIntegrazione;
  39. import org.openspcoop2.protocol.sdk.constants.ErroriIntegrazione;
  40. import org.slf4j.Logger;

  42. /**
  43.  * Classe che implementala gestione token
  44.  *
  45.  * @author Andrea Poli (apoli@link.it)
  46.  * @author $Author$
  47.  * @version $Rev$, $Date$
  48.  */

  50. public class GestioneToken {

  52.     private Logger log;
  53.     private String idTransazione;
  54.     private PdDContext pddContext;
  55.     private IProtocolFactory<?> protocolFactory;
  56.     public GestioneToken(Logger log, String idTransazione,
  57.             PdDContext pddContext, IProtocolFactory<?> protocolFactory) {
  58.         this.log = log;
  59.         this.idTransazione = idTransazione;
  60.         this.pddContext = pddContext;
  61.         this.protocolFactory = protocolFactory;
  62.     }
  63.     
  64.     public EsitoPresenzaTokenPortaDelegata verificaPresenzaToken(DatiInvocazionePortaDelegata datiInvocazione) {

  66.         EsitoPresenzaTokenPortaDelegata esito = (EsitoPresenzaTokenPortaDelegata) GestoreToken.verificaPosizioneToken(datiInvocazione, GestoreToken.PORTA_DELEGATA);
  67.         
  68.         if(esito.getEccezioneProcessamento()!=null) {
  69.             esito.setErroreIntegrazione(ErroriIntegrazione.ERRORE_5XX_GENERICO_PROCESSAMENTO_MESSAGGIO.
  70.                     get5XX_ErroreProcessamento(CodiceErroreIntegrazione.CODICE_560_GESTIONE_TOKEN));
  71.         }
  72.         else if(!esito.isPresente() &&
  73.             esito.getErrorMessage()==null) {
  74.             esito.setErroreIntegrazione(ErroriIntegrazione.ERRORE_443_TOKEN_NON_PRESENTE.getErroreIntegrazione());
  75.         }
  76.         
  77.         return esito;
  78.         
  79.     }
  80.     
  81.     public EsitoDynamicDiscoveryPortaDelegata dynamicDiscovery(DatiInvocazionePortaDelegata datiInvocazione, EsitoPresenzaToken token) throws TokenException {
  82.         try {
  83.             
  84.             IDSoggetto soggettoFruitore = getDominio(datiInvocazione);
  85.             IDServizio idServizio = getServizio(datiInvocazione);
  86.             Busta busta = getBusta(datiInvocazione, soggettoFruitore, idServizio);
  87.             
  88.             EsitoDynamicDiscoveryPortaDelegata esito = (EsitoDynamicDiscoveryPortaDelegata) GestoreToken.dynamicDiscovery(this.log, datiInvocazione, 
  89.                     this.pddContext, this.protocolFactory,
  90.                     token, GestoreToken.PORTA_DELEGATA,
  91.                     busta, soggettoFruitore, idServizio);
  92.             
  93.             if(esito.getEccezioneProcessamento()!=null) {
  94.                 esito.setErroreIntegrazione(ErroriIntegrazione.ERRORE_5XX_GENERICO_PROCESSAMENTO_MESSAGGIO.
  95.                         get5XX_ErroreProcessamento(CodiceErroreIntegrazione.CODICE_560_GESTIONE_TOKEN));
  96.             }
  97.             else if(!esito.isValido() &&
  98.                 esito.getErrorMessage()==null) {
  99.                 esito.setErroreIntegrazione(ErroriIntegrazione.ERRORE_444_TOKEN_NON_VALIDO.getErroreIntegrazione());
  100.             }
  101.             
  102.             return esito;
  103.             
  104.         }catch(Exception e) {
  105.             throw new TokenException(e.getMessage(),e); // errore di processamento
  106.         }
  107.     }
  108.     
  109.     public EsitoGestioneTokenPortaDelegata validazioneJWTToken(DatiInvocazionePortaDelegata datiInvocazione, EsitoPresenzaToken token, EsitoDynamicDiscovery esitoDynamicDiscovery) throws TokenException {     
  110.         try {
  111.         
  112.             IDSoggetto soggettoFruitore = getDominio(datiInvocazione);
  113.             IDServizio idServizio = getServizio(datiInvocazione);
  114.             Busta busta = getBusta(datiInvocazione, soggettoFruitore, idServizio);
  115.             
  116.             EsitoGestioneTokenPortaDelegata esito = (EsitoGestioneTokenPortaDelegata) GestoreToken.validazioneJWTToken(this.log, datiInvocazione, 
  117.                     this.pddContext, this.protocolFactory, 
  118.                     token, esitoDynamicDiscovery, GestoreToken.PORTA_DELEGATA,
  119.                     busta, soggettoFruitore, idServizio);
  120.             
  121.             if(esito.getEccezioneProcessamento()!=null) {
  122.                 esito.setErroreIntegrazione(ErroriIntegrazione.ERRORE_5XX_GENERICO_PROCESSAMENTO_MESSAGGIO.
  123.                         get5XX_ErroreProcessamento(CodiceErroreIntegrazione.CODICE_560_GESTIONE_TOKEN));
  124.             }
  125.             else if(!esito.isValido() &&
  126.                 esito.getErrorMessage()==null) {
  127.                 esito.setErroreIntegrazione(ErroriIntegrazione.ERRORE_444_TOKEN_NON_VALIDO.getErroreIntegrazione());
  128.             }
  129.             
  130.             return esito;
  131.             
  132.         }catch(Exception e) {
  133.             throw new TokenException(e.getMessage(),e); // errore di processamento
  134.         }   
  135.     }
  136.     
  137.     public EsitoGestioneTokenPortaDelegata introspectionToken(DatiInvocazionePortaDelegata datiInvocazione, EsitoPresenzaToken token, EsitoDynamicDiscovery esitoDynamicDiscovery) throws TokenException {
  138.         try {
  139.             
  140.             IDSoggetto soggettoFruitore = getDominio(datiInvocazione);
  141.             IDServizio idServizio = getServizio(datiInvocazione);
  142.             Busta busta = getBusta(datiInvocazione, soggettoFruitore, idServizio);
  143.             
  144.             EsitoGestioneTokenPortaDelegata esito = (EsitoGestioneTokenPortaDelegata) GestoreToken.introspectionToken(this.log, datiInvocazione, 
  145.                     this.pddContext, this.protocolFactory,
  146.                     token, esitoDynamicDiscovery, GestoreToken.PORTA_DELEGATA,
  147.                     busta, soggettoFruitore, idServizio);
  148.             
  149.             if(esito.getEccezioneProcessamento()!=null) {
  150.                 esito.setErroreIntegrazione(ErroriIntegrazione.ERRORE_5XX_GENERICO_PROCESSAMENTO_MESSAGGIO.
  151.                         get5XX_ErroreProcessamento(CodiceErroreIntegrazione.CODICE_560_GESTIONE_TOKEN));
  152.             }
  153.             else if(!esito.isValido() &&
  154.                 esito.getErrorMessage()==null) {
  155.                 esito.setErroreIntegrazione(ErroriIntegrazione.ERRORE_444_TOKEN_NON_VALIDO.getErroreIntegrazione());
  156.             }
  157.             
  158.             return esito;
  159.             
  160.         }catch(Exception e) {
  161.             throw new TokenException(e.getMessage(),e); // errore di processamento
  162.         }
  163.     }
  164.     
  165.     public EsitoGestioneTokenPortaDelegata userInfoToken(DatiInvocazionePortaDelegata datiInvocazione, EsitoPresenzaToken token, EsitoDynamicDiscovery esitoDynamicDiscovery) throws TokenException {
  166.         try {
  167.             
  168.             IDSoggetto soggettoFruitore = getDominio(datiInvocazione);
  169.             IDServizio idServizio = getServizio(datiInvocazione);
  170.             Busta busta = getBusta(datiInvocazione, soggettoFruitore, idServizio);
  171.             
  172.             EsitoGestioneTokenPortaDelegata esito = (EsitoGestioneTokenPortaDelegata) GestoreToken.userInfoToken(this.log, datiInvocazione, 
  173.                     this.pddContext, this.protocolFactory,
  174.                     token, esitoDynamicDiscovery, GestoreToken.PORTA_DELEGATA,
  175.                     busta, soggettoFruitore, idServizio);
  176.             
  177.             if(esito.getEccezioneProcessamento()!=null) {
  178.                 esito.setErroreIntegrazione(ErroriIntegrazione.ERRORE_5XX_GENERICO_PROCESSAMENTO_MESSAGGIO.
  179.                         get5XX_ErroreProcessamento(CodiceErroreIntegrazione.CODICE_560_GESTIONE_TOKEN));
  180.             }
  181.             else if(!esito.isValido() &&
  182.                 esito.getErrorMessage()==null) {
  183.                 esito.setErroreIntegrazione(ErroriIntegrazione.ERRORE_444_TOKEN_NON_VALIDO.getErroreIntegrazione());
  184.             }
  185.             
  186.             return esito;
  187.             
  188.         }catch(Exception e) {
  189.             throw new TokenException(e.getMessage(),e); // errore di processamento
  190.         }
  191.     }
  192.     
  193.     public void forwardToken(DatiInvocazionePortaDelegata datiInvocazione, EsitoPresenzaTokenPortaDelegata esitoPresenzaToken,
  194.             EsitoGestioneToken esitoValidazioneJWT, EsitoGestioneToken esitoIntrospection, EsitoGestioneToken esitoUserInfo,
  195.             InformazioniToken informazioniTokenNormalizzate) throws TokenException {
  196.         try {
  197.             
  198.             IDSoggetto soggettoFruitore = getDominio(datiInvocazione);
  199.             IDServizio idServizio = getServizio(datiInvocazione);
  200.             Busta busta = getBusta(datiInvocazione, soggettoFruitore, idServizio);
  201.             
  202.             GestoreToken.forwardToken(this.log, this.idTransazione,
  203.                     datiInvocazione, esitoPresenzaToken, 
  204.                     esitoValidazioneJWT, esitoIntrospection, esitoUserInfo,
  205.                     informazioniTokenNormalizzate,
  206.                     GestoreToken.PORTA_DELEGATA,
  207.                     this.pddContext, busta);
  208.             
  209.         }catch(Exception e) {
  210.             throw new TokenException(e.getMessage(),e); // errore di processamento
  211.         }
  212.     }
  213.     
  214.     private IDSoggetto getDominio(DatiInvocazionePortaDelegata datiInvocazione) {
  215.         IDSoggetto soggetto = null;
  216.         if(datiInvocazione.getPd()!=null) {
  217.             soggetto = new IDSoggetto(datiInvocazione.getPd().getTipoSoggettoProprietario(), datiInvocazione.getPd().getNomeSoggettoProprietario());
  218.         }
  219.         return soggetto;
  220.     }
  221.     private IDServizio getServizio(DatiInvocazionePortaDelegata datiInvocazione) throws DriverRegistroServiziException {
  222.         IDServizio servizio = null;
  223.         if(datiInvocazione.getPd()!=null) {
  224.             servizio = IDServizioFactory.getInstance().getIDServizioFromValues(datiInvocazione.getPd().getServizio().getTipo(), datiInvocazione.getPd().getServizio().getNome(), 
  225.                     datiInvocazione.getPd().getSoggettoErogatore().getTipo(), datiInvocazione.getPd().getSoggettoErogatore().getNome(), 
  226.                     datiInvocazione.getPd().getServizio().getVersione());
  227.         }
  228.         return servizio;
  229.     }
  230.     
  231.     private Busta getBusta(DatiInvocazionePortaDelegata datiInvocazione, IDSoggetto soggettoFruitore, IDServizio idServizio) {
  232.         Busta busta = new Busta(this.protocolFactory.getProtocol());
  233.         if(soggettoFruitore!=null) {
  234.             busta.setTipoMittente(soggettoFruitore.getTipo());
  235.             busta.setMittente(soggettoFruitore.getNome());
  236.         }
  237.         if(idServizio!=null) {
  238.             if(idServizio.getSoggettoErogatore()!=null) {
  239.                 busta.setTipoDestinatario(idServizio.getSoggettoErogatore().getTipo());
  240.                 busta.setDestinatario(idServizio.getSoggettoErogatore().getNome());
  241.             }
  242.             busta.setTipoServizio(idServizio.getTipo());
  243.             busta.setServizio(idServizio.getNome());
  244.             busta.setVersioneServizio(idServizio.getVersione());
  245.             if(datiInvocazione.getRequestInfo()!=null && datiInvocazione.getRequestInfo().getIdServizio()!=null) {
  246.                 busta.setAzione(datiInvocazione.getRequestInfo().getIdServizio().getAzione());
  247.             }
  248.         }
  249.         return busta;
  250.     }
  251.   
  252. }
Created with JaCoCo 0.8.8.202204050719