RicezioneContenutiApplicativiGestioneToken.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.  */
  20. package org.openspcoop2.pdd.services.core;

  22. import java.util.List;

  24. import org.openspcoop2.core.config.GestioneTokenAutenticazione;
  25. import org.openspcoop2.core.config.PortaDelegata;
  26. import org.openspcoop2.core.id.IDPortaDelegata;
  27. import org.openspcoop2.core.id.IDSoggetto;
  28. import org.openspcoop2.core.transazioni.utils.CredenzialiMittente;
  29. import org.openspcoop2.message.OpenSPCoop2Message;
  30. import org.openspcoop2.pdd.config.ConfigurazionePdDManager;
  31. import org.openspcoop2.pdd.config.OpenSPCoop2Properties;
  32. import org.openspcoop2.pdd.core.CostantiPdD;
  33. import org.openspcoop2.pdd.core.PdDContext;
  34. import org.openspcoop2.pdd.core.autenticazione.GestoreAutenticazione;
  35. import org.openspcoop2.pdd.core.handlers.InRequestContext;
  36. import org.openspcoop2.pdd.core.state.IOpenSPCoopState;
  37. import org.openspcoop2.pdd.core.token.GestoreToken;
  38. import org.openspcoop2.pdd.core.token.InformazioniToken;
  39. import org.openspcoop2.pdd.core.token.PolicyGestioneToken;
  40. import org.openspcoop2.pdd.core.token.pd.EsitoDynamicDiscoveryPortaDelegata;
  41. import org.openspcoop2.pdd.core.token.pd.EsitoGestioneTokenPortaDelegata;
  42. import org.openspcoop2.pdd.core.token.pd.EsitoPresenzaTokenPortaDelegata;
  43. import org.openspcoop2.pdd.core.token.pd.GestioneToken;
  44. import org.openspcoop2.pdd.core.transazioni.Transaction;
  45. import org.openspcoop2.pdd.logger.MsgDiagnostico;
  46. import org.openspcoop2.pdd.services.error.RicezioneContenutiApplicativiInternalErrorGenerator;
  47. import org.openspcoop2.protocol.sdk.IProtocolFactory;
  48. import org.openspcoop2.protocol.sdk.constants.CodiceErroreIntegrazione;
  49. import org.openspcoop2.protocol.sdk.constants.ErroreIntegrazione;
  50. import org.openspcoop2.protocol.sdk.constants.ErroriIntegrazione;
  51. import org.openspcoop2.protocol.sdk.constants.IntegrationFunctionError;
  52. import org.openspcoop2.protocol.sdk.state.RequestInfo;
  53. import org.openspcoop2.utils.transport.http.HttpConstants;
  54. import org.slf4j.Logger;

  56. /**
  57.  * RicezioneContenutiApplicativiGestioneToken
  58.  * 
  59.  * @author Poli Andrea (apoli@link.it)
  60.  * @author $Author$
  61.  * @version $Rev$, $Date$
  62.  */
  63. public class RicezioneContenutiApplicativiGestioneToken {

  65.     private MsgDiagnostico msgDiag;
  66.     private Logger logCore;
  67.     
  68.     private PortaDelegata portaDelegata;
  69.     private IDPortaDelegata identificativoPortaDelegata;
  70.     
  71.     private OpenSPCoop2Message requestMessage;
  72.     
  73.     private RicezioneContenutiApplicativiContext msgContext;
  74.     private RicezioneContenutiApplicativiInternalErrorGenerator generatoreErrore;
  75.     private InRequestContext inRequestContext;
  76.     
  77.     private ConfigurazionePdDManager configurazionePdDReader;
  78.     
  79.     private PdDContext pddContext;
  80.     private String idTransazione;
  81.     private IOpenSPCoopState openspcoopstate;
  82.     private Transaction transaction;
  83.     private RequestInfo requestInfo;
  84.     
  85.     private IProtocolFactory<?> protocolFactory;
  86.     
  87.     private IDSoggetto identitaPdD;
  88.     
  89.     public RicezioneContenutiApplicativiGestioneToken(MsgDiagnostico msgDiag, Logger logCore,
  90.             PortaDelegata portaDelegata, IDPortaDelegata identificativoPortaDelegata,
  91.             OpenSPCoop2Message requestMessage,
  92.             RicezioneContenutiApplicativiContext msgContext, RicezioneContenutiApplicativiInternalErrorGenerator generatoreErrore, InRequestContext inRequestContext,
  93.             ConfigurazionePdDManager configurazionePdDReader,
  94.             PdDContext pddContext, String idTransazione,
  95.             IOpenSPCoopState openspcoopstate, Transaction transaction, RequestInfo requestInfo,
  96.             IProtocolFactory<?> protocolFactory,
  97.             IDSoggetto identitaPdD) {
  98.         this.msgDiag = msgDiag;
  99.         this.logCore = logCore;
  100.                 
  101.         this.portaDelegata = portaDelegata;
  102.         this.identificativoPortaDelegata = identificativoPortaDelegata;
  103.         
  104.         this.requestMessage = requestMessage;
  105.         
  106.         this.msgContext = msgContext;
  107.         this.generatoreErrore = generatoreErrore;
  108.         this.inRequestContext = inRequestContext;
  109.         
  110.         this.configurazionePdDReader = configurazionePdDReader;
  111.         
  112.         this.pddContext = pddContext;
  113.         this.idTransazione = idTransazione;
  114.         this.openspcoopstate = openspcoopstate;
  115.         this.transaction = transaction;
  116.         this.requestInfo = requestInfo; 
  117.         
  118.         this.protocolFactory = protocolFactory;
  119.         
  120.         this.identitaPdD = identitaPdD;
  121.         
  122.     }
  123.     
  124.     // Result
  125.     private GestioneTokenAutenticazione gestioneTokenAutenticazione = null;
  126.     private String token = null;
  127.     private String tipoGestioneToken = null;
  128.     
  129.     public GestioneTokenAutenticazione getGestioneTokenAutenticazione() {
  130.         return this.gestioneTokenAutenticazione;
  131.     }
  132.     public String getToken() {
  133.         return this.token;
  134.     }
  135.     public String getTipoGestioneToken() {
  136.         return this.tipoGestioneToken;
  137.     }
  138.     
  139.     public boolean process() {
  140.         
  141.         try {
  142.             this.tipoGestioneToken = this.configurazionePdDReader.getGestioneToken(this.portaDelegata);
  143.             if(this.portaDelegata!=null && this.portaDelegata.getGestioneToken()!=null) {
  144.                 this.gestioneTokenAutenticazione = this.portaDelegata.getGestioneToken().getAutenticazione();
  145.             }
  146.         } catch (Exception e) {
  147.             this.msgDiag.logErroreGenerico(e, "letturaToken");
  148.             this.logCore.error(this.msgDiag.getMessaggio_replaceKeywords("letturaToken"),e);
  149.             this.openspcoopstate.releaseResource();
  150.             if (this.msgContext.isGestioneRisposta()) {
  151.                 this.msgContext.setMessageResponse((this.generatoreErrore.build(this.pddContext,IntegrationFunctionError.INTERNAL_REQUEST_ERROR,
  152.                         ErroriIntegrazione.ERRORE_5XX_GENERICO_PROCESSAMENTO_MESSAGGIO.
  153.                         get5XX_ErroreProcessamento(CodiceErroreIntegrazione.CODICE_536_CONFIGURAZIONE_NON_DISPONIBILE), e,null)));
  154.             }
  155.             return false;
  156.         }
  157.         
  158.         String gestioneTokenPrefix = "processo di gestione token ["+ this.tipoGestioneToken + "] ";
  159.         
  160.         this.msgDiag.mediumDebug("GestioneToken...");
  161.         this.msgContext.getIntegrazione().setTipoGestioneToken(this.tipoGestioneToken);
  162.         if (this.tipoGestioneToken == null) {

  164.             this.msgDiag.logPersonalizzato("gestioneTokenDisabilitata");
  165.             
  166.         } else {

  168.             this.transaction.getTempiElaborazione().startToken();
  169.             try {
  170.             
  171.                 ErroreIntegrazione errore = null;
  172.                 Exception eGestioneToken = null;
  173.                 OpenSPCoop2Message errorMessageGestioneToken = null;
  174.                 String wwwAuthenticateErrorHeader = null;
  175.                 boolean fineGestione = false;
  176.                 IntegrationFunctionError integrationFunctionError = null;
  177.                 try {
  178.                     
  179.                     PolicyGestioneToken policyGestioneToken = this.configurazionePdDReader.getPolicyGestioneToken(this.portaDelegata, this.requestInfo);
  180.                     
  181.                     this.pddContext.addObject(org.openspcoop2.pdd.core.token.Costanti.PDD_CONTEXT_TOKEN_POLICY, 
  182.                             policyGestioneToken.getName());
  183.                     this.pddContext.addObject(org.openspcoop2.pdd.core.token.Costanti.PDD_CONTEXT_TOKEN_REALM,
  184.                             policyGestioneToken.getRealm());
  185.                     this.pddContext.addObject(org.openspcoop2.pdd.core.token.Costanti.PDD_CONTEXT_TOKEN_MESSAGE_ERROR_BODY_EMPTY,
  186.                             policyGestioneToken.isMessageErrorGenerateEmptyMessage());
  187.                     this.pddContext.addObject(org.openspcoop2.pdd.core.token.Costanti.PDD_CONTEXT_TOKEN_MESSAGE_ERROR_GENERIC_MESSAGE,
  188.                             policyGestioneToken.isMessageErrorGenerateGenericMessage());
  189.                     
  190.                     this.msgDiag.addKeyword(CostantiPdD.KEY_TOKEN_POLICY_GESTIONE, this.tipoGestioneToken);
  191.                     this.msgContext.getIntegrazione().setTokenPolicy(this.tipoGestioneToken);
  192.                     this.msgDiag.addKeyword(CostantiPdD.KEY_TOKEN_POLICY_AZIONI, policyGestioneToken.getLabelAzioniGestioneToken());
  193.                     this.msgContext.getIntegrazione().setTokenPolicyActions(policyGestioneToken.getAzioniGestioneToken());
  194.                     this.msgDiag.addKeyword(CostantiPdD.KEY_TOKEN_TIPO, policyGestioneToken.getLabelTipoToken());
  195.                     this.msgDiag.logPersonalizzato("gestioneTokenInCorso");
  196.                     
  197.                     org.openspcoop2.pdd.core.token.pd.DatiInvocazionePortaDelegata datiInvocazione = new org.openspcoop2.pdd.core.token.pd.DatiInvocazionePortaDelegata();
  198.                     datiInvocazione.setInfoConnettoreIngresso(this.inRequestContext.getConnettore());
  199.                     datiInvocazione.setState(this.openspcoopstate.getStatoRichiesta());
  200.                     datiInvocazione.setIdModulo(this.msgContext.getIdModulo());
  201.                     datiInvocazione.setMessage(this.requestMessage);
  202.                     datiInvocazione.setIdPD(this.identificativoPortaDelegata);
  203.                     datiInvocazione.setPd(this.portaDelegata);      
  204.                     datiInvocazione.setPolicyGestioneToken(policyGestioneToken);
  205.                     datiInvocazione.setRequestInfo(this.requestInfo);
  206.                     
  207.                     GestoreToken.validazioneConfigurazione(datiInvocazione); // assicura che la configurazione sia corretta
  208.                     
  209.                     GestioneToken gestioneTokenEngine = new GestioneToken(this.logCore, this.idTransazione, this.pddContext, this.protocolFactory);
  210.                     
  211.                     // cerco token
  212.                     
  213.                     this.msgDiag.addKeyword(CostantiPdD.KEY_TOKEN_POSIZIONE, policyGestioneToken.getLabelPosizioneToken());
  214.                     this.msgDiag.logPersonalizzato("gestioneTokenInCorso.verificaPresenzaToken");
  215.                     
  216.                     EsitoPresenzaTokenPortaDelegata esitoPresenzaToken = gestioneTokenEngine.verificaPresenzaToken(datiInvocazione);
  217.                     EsitoDynamicDiscoveryPortaDelegata esitoDynamicDiscovery = null;
  218.                     EsitoGestioneTokenPortaDelegata esitoValidazioneToken = null;
  219.                     EsitoGestioneTokenPortaDelegata esitoIntrospectionToken = null;
  220.                     EsitoGestioneTokenPortaDelegata esitoUserInfoToken = null;
  221.                     if(esitoPresenzaToken.isPresente()) {
  222.                         this.msgDiag.addKeyword(CostantiPdD.KEY_TOKEN, esitoPresenzaToken.getToken());
  223.                         this.msgDiag.logPersonalizzato("gestioneTokenInCorso.verificaPresenzaToken.trovato"); // stampa del token info
  224.                         
  225.                         this.token = esitoPresenzaToken.getToken();
  226.                         this.pddContext.addObject(org.openspcoop2.pdd.core.token.Costanti.PDD_CONTEXT_TOKEN_POSIZIONE, esitoPresenzaToken);
  227.                         
  228.                         this.msgDiag.logPersonalizzato("gestioneTokenInCorso.verificaPresenzaToken.completataSuccesso");
  229.     
  230.                         
  231.                         // dynamicDiscovery
  232.                         if(!fineGestione) {
  233.                             
  234.                             if(policyGestioneToken.isDynamicDiscovery()) {
  235.                             
  236.                                 this.msgDiag.addKeyword(CostantiPdD.KEY_TOKEN_ENDPOINT_SERVIZIO_DYNAMIC_DISCOVERY, policyGestioneToken.getDynamicDiscoveryEndpoint());
  237.                                 
  238.                                 this.msgDiag.logPersonalizzato("gestioneTokenInCorso.dynamicDiscovery");
  239.                                 
  240.                                 esitoDynamicDiscovery = gestioneTokenEngine.dynamicDiscovery(datiInvocazione, esitoPresenzaToken);
  241.                                 if(esitoDynamicDiscovery.isValido()) {
  242.                                     
  243.                                     this.msgDiag.logPersonalizzato("gestioneTokenInCorso.dynamicDiscovery.completataSuccesso");
  244.                                     
  245.                                     this.msgDiag.addKeyword(CostantiPdD.KEY_DYNAMIC_DISCOVERY_INFO, esitoDynamicDiscovery.getDynamicDiscovery().getRawResponse());
  246.                                     
  247.                                     this.pddContext.addObject(org.openspcoop2.pdd.core.token.Costanti.PDD_CONTEXT_TOKEN_ESITO_DYNAMIC_DISCOVERY, esitoDynamicDiscovery);
  248.                                     
  249.                                     if(esitoDynamicDiscovery.isInCache()) {
  250.                                         this.msgDiag.logPersonalizzato("gestioneTokenInCorso.dynamicDiscovery.inCache");
  251.                                     }
  252.                                     else {
  253.                                         this.msgDiag.logPersonalizzato("gestioneTokenInCorso.dynamicDiscovery.validato");
  254.                                     }
  255.                                 }
  256.                                 else {
  257.                                     
  258.                                     this.msgDiag.addKeyword(CostantiPdD.KEY_ERRORE_PROCESSAMENTO, esitoDynamicDiscovery.getDetails());
  259.                                     // La gestione di fallire o dare warning è delegata alla funzionalità stessa jwt/introspection/userInfo che sono le azioni
  260.                                     /**if(policyGestioneToken.isDynamicDiscoveryWarningOnly()) {
  261.                                         this.msgDiag.logPersonalizzato("gestioneTokenInCorso.dynamicDiscovery.warningOnly.fallita");
  262.                                     }
  263.                                     else {
  264.                                         this.msgDiag.logPersonalizzato("gestioneTokenInCorso.dynamicDiscovery.fallita");
  265.                                         fineGestione = true;
  266.                                     }*/
  267.                                     this.msgDiag.logPersonalizzato("gestioneTokenInCorso.dynamicDiscovery.fallita");
  268.                                     
  269.                                     String msgErrore = gestioneTokenPrefix+"(Introspection) fallito: " + esitoDynamicDiscovery.getDetails();
  270.                                     if(esitoDynamicDiscovery.getEccezioneProcessamento()!=null) {
  271.                                         this.logCore.error(msgErrore,esitoDynamicDiscovery.getEccezioneProcessamento());
  272.                                     }
  273.                                     else {
  274.                                         this.logCore.error(msgErrore);
  275.                                     }
  276.                                 
  277.                                     // La gestione di fallire o dare warning è delegata alla funzionalità stessa jwt/introspection/userInfo che sono le azioni
  278.                                     /**
  279.                                     errore = esitoDynamicDiscovery.getErroreIntegrazione();
  280.                                     eGestioneToken = esitoDynamicDiscovery.getEccezioneProcessamento();
  281.                                     errorMessageGestioneToken = esitoDynamicDiscovery.getErrorMessage();
  282.                                     wwwAuthenticateErrorHeader = esitoDynamicDiscovery.getWwwAuthenticateErrorHeader();
  283.                                     integrationFunctionError = esitoDynamicDiscovery.getIntegrationFunctionError();
  284.                                     **/
  285.                                     
  286.                                 }
  287.                             }
  288.                             else {
  289.                                 this.msgDiag.logPersonalizzato("gestioneTokenInCorso.dynamicDiscovery.disabilitata");
  290.                             }
  291.                             
  292.                         }
  293.                         
  294.                         
  295.                         // validazione jwt
  296.                         if(!fineGestione) {
  297.                             
  298.                             if(policyGestioneToken.isValidazioneJWT()) {
  299.                             
  300.                                 this.msgDiag.logPersonalizzato("gestioneTokenInCorso.validazioneToken");
  301.                                 
  302.                                 esitoValidazioneToken = gestioneTokenEngine.validazioneJWTToken(datiInvocazione, esitoPresenzaToken, esitoDynamicDiscovery);
  303.                                 if(esitoValidazioneToken.isValido()) {
  304.                                     
  305.                                     this.msgDiag.logPersonalizzato("gestioneTokenInCorso.validazioneToken.completataSuccesso");
  306.                                     
  307.                                     this.msgDiag.addKeyword(CostantiPdD.KEY_TOKEN_INFO, esitoValidazioneToken.getInformazioniToken().getRawResponse());
  308.                                     
  309.                                     this.pddContext.addObject(org.openspcoop2.pdd.core.token.Costanti.PDD_CONTEXT_TOKEN_ESITO_VALIDAZIONE, esitoValidazioneToken);
  310.                                     
  311.                                     if(esitoValidazioneToken.isInCache()) {
  312.                                         this.msgDiag.logPersonalizzato("gestioneTokenInCorso.validazioneToken.inCache");
  313.                                     }
  314.                                     else {
  315.                                         this.msgDiag.logPersonalizzato("gestioneTokenInCorso.validazioneToken.validato");
  316.                                     }
  317.                                 }
  318.                                 else {
  319.                                     
  320.                                     this.msgDiag.addKeyword(CostantiPdD.KEY_ERRORE_PROCESSAMENTO, esitoValidazioneToken.getDetails());
  321.                                     if(policyGestioneToken.isValidazioneJWTWarningOnly()) {
  322.                                         this.msgDiag.logPersonalizzato("gestioneTokenInCorso.validazioneToken.warningOnly.fallita");
  323.                                     }
  324.                                     else {
  325.                                         this.msgDiag.logPersonalizzato("gestioneTokenInCorso.validazioneToken.fallita");
  326.                                         fineGestione = true;
  327.                                     }
  328.                                     
  329.                                     String msgErrore = gestioneTokenPrefix+"(validazione JWT) fallito: " + esitoValidazioneToken.getDetails();
  330.                                     if(esitoValidazioneToken.getEccezioneProcessamento()!=null) {
  331.                                         this.logCore.error(msgErrore,esitoValidazioneToken.getEccezioneProcessamento());
  332.                                     }
  333.                                     else {
  334.                                         this.logCore.error(msgErrore);
  335.                                     }
  336.                                 
  337.                                     errore = esitoValidazioneToken.getErroreIntegrazione();
  338.                                     eGestioneToken = esitoValidazioneToken.getEccezioneProcessamento();
  339.                                     errorMessageGestioneToken = esitoValidazioneToken.getErrorMessage();
  340.                                     wwwAuthenticateErrorHeader = esitoValidazioneToken.getWwwAuthenticateErrorHeader();
  341.                                     integrationFunctionError = esitoValidazioneToken.getIntegrationFunctionError();
  342.                                     
  343.                                 }
  344.                             }
  345.                             else {
  346.                                 this.msgDiag.logPersonalizzato("gestioneTokenInCorso.validazioneToken.disabilitata");
  347.                             }
  348.                             
  349.                         }
  350.                         
  351.                         
  352.                         // introspection
  353.                         if(!fineGestione) {
  354.                             
  355.                             if(policyGestioneToken.isIntrospection()) {
  356.                             
  357.                                 String endpoint = null;
  358.                                 if(esitoDynamicDiscovery!=null) {
  359.                                     if(esitoDynamicDiscovery.isValido() && esitoDynamicDiscovery.getDynamicDiscovery()!=null) {
  360.                                         endpoint = esitoDynamicDiscovery.getDynamicDiscovery().getIntrospectionEndpoint();
  361.                                     }
  362.                                     else {
  363.                                         endpoint = "dynamic discovery";
  364.                                     }
  365.                                 }
  366.                                 else {
  367.                                     endpoint = policyGestioneToken.getIntrospectionEndpoint();
  368.                                 }
  369.                                 this.msgDiag.addKeyword(CostantiPdD.KEY_TOKEN_ENDPOINT_SERVIZIO_INTROSPECTION, endpoint);
  370.                                 
  371.                                 this.msgDiag.logPersonalizzato("gestioneTokenInCorso.introspectionToken");
  372.                                 
  373.                                 esitoIntrospectionToken = gestioneTokenEngine.introspectionToken(datiInvocazione, esitoPresenzaToken, esitoDynamicDiscovery);
  374.                                 if(esitoIntrospectionToken.isValido()) {
  375.                                     
  376.                                     this.msgDiag.logPersonalizzato("gestioneTokenInCorso.introspectionToken.completataSuccesso");
  377.                                     
  378.                                     this.msgDiag.addKeyword(CostantiPdD.KEY_TOKEN_INFO, esitoIntrospectionToken.getInformazioniToken().getRawResponse());
  379.                                     
  380.                                     this.pddContext.addObject(org.openspcoop2.pdd.core.token.Costanti.PDD_CONTEXT_TOKEN_ESITO_INTROSPECTION, esitoIntrospectionToken);
  381.                                     
  382.                                     if(esitoIntrospectionToken.isInCache()) {
  383.                                         this.msgDiag.logPersonalizzato("gestioneTokenInCorso.introspectionToken.inCache");
  384.                                     }
  385.                                     else {
  386.                                         this.msgDiag.logPersonalizzato("gestioneTokenInCorso.introspectionToken.validato");
  387.                                     }
  388.                                 }
  389.                                 else {
  390.                                     
  391.                                     this.msgDiag.addKeyword(CostantiPdD.KEY_ERRORE_PROCESSAMENTO, esitoIntrospectionToken.getDetails());
  392.                                     if(policyGestioneToken.isIntrospectionWarningOnly()) {
  393.                                         this.msgDiag.logPersonalizzato("gestioneTokenInCorso.introspectionToken.warningOnly.fallita");
  394.                                     }
  395.                                     else {
  396.                                         this.msgDiag.logPersonalizzato("gestioneTokenInCorso.introspectionToken.fallita");
  397.                                         fineGestione = true;
  398.                                     }
  399.                                     
  400.                                     String msgErrore = gestioneTokenPrefix+"(Introspection) fallito: " + esitoIntrospectionToken.getDetails();
  401.                                     if(esitoIntrospectionToken.getEccezioneProcessamento()!=null) {
  402.                                         this.logCore.error(msgErrore,esitoIntrospectionToken.getEccezioneProcessamento());
  403.                                     }
  404.                                     else {
  405.                                         this.logCore.error(msgErrore);
  406.                                     }
  407.                                 
  408.                                     errore = esitoIntrospectionToken.getErroreIntegrazione();
  409.                                     eGestioneToken = esitoIntrospectionToken.getEccezioneProcessamento();
  410.                                     errorMessageGestioneToken = esitoIntrospectionToken.getErrorMessage();
  411.                                     wwwAuthenticateErrorHeader = esitoIntrospectionToken.getWwwAuthenticateErrorHeader();
  412.                                     integrationFunctionError = esitoIntrospectionToken.getIntegrationFunctionError();
  413.                                     
  414.                                 }
  415.                             }
  416.                             else {
  417.                                 this.msgDiag.logPersonalizzato("gestioneTokenInCorso.introspectionToken.disabilitata");
  418.                             }
  419.                             
  420.                         }
  421.                         
  422.                         
  423.                         // userInfo
  424.                         if(!fineGestione) {
  425.                             
  426.                             if(policyGestioneToken.isUserInfo()) {
  427.                             
  428.                                 String endpoint = null;
  429.                                 if(esitoDynamicDiscovery!=null) {
  430.                                     if(esitoDynamicDiscovery.isValido() && esitoDynamicDiscovery.getDynamicDiscovery()!=null) {
  431.                                         endpoint = esitoDynamicDiscovery.getDynamicDiscovery().getUserinfoEndpoint();
  432.                                     }
  433.                                     else {
  434.                                         endpoint = "dynamic discovery";
  435.                                     }
  436.                                 }
  437.                                 else {
  438.                                     endpoint = policyGestioneToken.getUserInfoEndpoint();
  439.                                 }
  440.                                 this.msgDiag.addKeyword(CostantiPdD.KEY_TOKEN_ENDPOINT_SERVIZIO_USER_INFO, endpoint);
  441.                                 
  442.                                 this.msgDiag.logPersonalizzato("gestioneTokenInCorso.userInfoToken");
  443.                                 
  444.                                 esitoUserInfoToken = gestioneTokenEngine.userInfoToken(datiInvocazione, esitoPresenzaToken, esitoDynamicDiscovery);
  445.                                 if(esitoUserInfoToken.isValido()) {
  446.                                     
  447.                                     this.msgDiag.logPersonalizzato("gestioneTokenInCorso.userInfoToken.completataSuccesso");
  448.                                     
  449.                                     this.msgDiag.addKeyword(CostantiPdD.KEY_TOKEN_INFO, esitoUserInfoToken.getInformazioniToken().getRawResponse());
  450.                                     
  451.                                     this.pddContext.addObject(org.openspcoop2.pdd.core.token.Costanti.PDD_CONTEXT_TOKEN_ESITO_USER_INFO, esitoUserInfoToken);
  452.                                     
  453.                                     if(esitoUserInfoToken.isInCache()) {
  454.                                         this.msgDiag.logPersonalizzato("gestioneTokenInCorso.userInfoToken.inCache");
  455.                                     }
  456.                                     else {
  457.                                         this.msgDiag.logPersonalizzato("gestioneTokenInCorso.userInfoToken.validato");
  458.                                     }
  459.                                 }
  460.                                 else {
  461.                                     
  462.                                     this.msgDiag.addKeyword(CostantiPdD.KEY_ERRORE_PROCESSAMENTO, esitoUserInfoToken.getDetails());
  463.                                     if(policyGestioneToken.isUserInfoWarningOnly()) {
  464.                                         this.msgDiag.logPersonalizzato("gestioneTokenInCorso.userInfoToken.warningOnly.fallita");
  465.                                     }
  466.                                     else {
  467.                                         this.msgDiag.logPersonalizzato("gestioneTokenInCorso.userInfoToken.fallita");
  468.                                         fineGestione = true;
  469.                                     }
  470.                                     
  471.                                     String msgErrore = gestioneTokenPrefix+"(UserInfo) fallito: " + esitoUserInfoToken.getDetails();
  472.                                     if(esitoUserInfoToken.getEccezioneProcessamento()!=null) {
  473.                                         this.logCore.error(msgErrore,esitoUserInfoToken.getEccezioneProcessamento());
  474.                                     }
  475.                                     else {
  476.                                         this.logCore.error(msgErrore);
  477.                                     }
  478.                                 
  479.                                     errore = esitoUserInfoToken.getErroreIntegrazione();
  480.                                     eGestioneToken = esitoUserInfoToken.getEccezioneProcessamento();
  481.                                     errorMessageGestioneToken = esitoUserInfoToken.getErrorMessage();
  482.                                     wwwAuthenticateErrorHeader = esitoUserInfoToken.getWwwAuthenticateErrorHeader();
  483.                                     integrationFunctionError = esitoUserInfoToken.getIntegrationFunctionError();
  484.                                     
  485.                                 }
  486.                             }
  487.                             else {
  488.                                 this.msgDiag.logPersonalizzato("gestioneTokenInCorso.userInfoToken.disabilitata");
  489.                             }
  490.                             
  491.                         }
  492.                         
  493.                         
  494.                     }
  495.                     else {
  496.                         
  497.                         if(!policyGestioneToken.isTokenOpzionale()) {
  498.                         
  499.                             this.msgDiag.addKeyword(CostantiPdD.KEY_ERRORE_PROCESSAMENTO, esitoPresenzaToken.getDetails());
  500.                             this.msgDiag.logPersonalizzato("gestioneTokenInCorso.verificaPresenzaToken.fallita");
  501.                             
  502.                             fineGestione = true;
  503.                             
  504.                             String msgErrore = gestioneTokenPrefix+"fallito: " + esitoPresenzaToken.getDetails();
  505.                             if(esitoPresenzaToken.getEccezioneProcessamento()!=null) {
  506.                                 this.logCore.error(msgErrore,esitoPresenzaToken.getEccezioneProcessamento());
  507.                             }
  508.                             else {
  509.                                 this.logCore.error(msgErrore);
  510.                             }
  511.                     
  512.                             errore = esitoPresenzaToken.getErroreIntegrazione();
  513.                             eGestioneToken = esitoPresenzaToken.getEccezioneProcessamento();
  514.                             errorMessageGestioneToken = esitoPresenzaToken.getErrorMessage();
  515.                             wwwAuthenticateErrorHeader = esitoPresenzaToken.getWwwAuthenticateErrorHeader();
  516.                             integrationFunctionError = IntegrationFunctionError.TOKEN_NOT_FOUND;
  517.                         
  518.                         }
  519.                         
  520.                     }
  521.             
  522.                     if(fineGestione) {
  523.                         if(esitoPresenzaToken.isPresente()) {
  524.                             this.pddContext.addObject(org.openspcoop2.core.constants.Costanti.ERRORE_TOKEN, "true");
  525.                         }
  526.                         else {
  527.                             this.pddContext.addObject(org.openspcoop2.core.constants.Costanti.TOKEN_NON_PRESENTE, "true");
  528.                         }
  529.                         this.msgDiag.logPersonalizzato("gestioneTokenFallita");
  530.                         
  531.                         List<InformazioniToken> listaEsiti = GestoreToken.getInformazioniTokenNonValide(esitoValidazioneToken, esitoIntrospectionToken, esitoUserInfoToken);
  532.                         InformazioniToken informazioniTokenNormalizzate = null;
  533.                         if(listaEsiti!=null && !listaEsiti.isEmpty()) {
  534.                             informazioniTokenNormalizzate = GestoreToken.normalizeInformazioniToken(listaEsiti);
  535.                             informazioniTokenNormalizzate.setValid(false);
  536.                         }
  537.                         if(informazioniTokenNormalizzate==null && esitoDynamicDiscovery!=null && esitoDynamicDiscovery.getDynamicDiscovery()!=null) {
  538.                             informazioniTokenNormalizzate = new InformazioniToken();
  539.                             if(esitoPresenzaToken!=null) {
  540.                                 informazioniTokenNormalizzate.setToken(esitoPresenzaToken.getToken());
  541.                             }
  542.                             informazioniTokenNormalizzate.setDynamicDiscovery(esitoDynamicDiscovery.getDynamicDiscovery());
  543.                         }
  544.                         if(informazioniTokenNormalizzate!=null) {
  545.                             
  546.                             if(esitoDynamicDiscovery!=null) {
  547.                                 informazioniTokenNormalizzate.setDynamicDiscovery(esitoDynamicDiscovery.getDynamicDiscovery());
  548.                             }
  549.                             
  550.                             this.pddContext.addObject(org.openspcoop2.pdd.core.token.Costanti.PDD_CONTEXT_TOKEN_INFORMAZIONI_NORMALIZZATE, informazioniTokenNormalizzate);
  551.                             
  552.                             this.transaction.setInformazioniToken(informazioniTokenNormalizzate);
  553.                         }
  554.                     }
  555.                     else {
  556.                         if(esitoPresenzaToken.isPresente()) {
  557.                             List<InformazioniToken> listaEsiti = GestoreToken.getInformazioniTokenValide(esitoValidazioneToken, esitoIntrospectionToken, esitoUserInfoToken);
  558.                             InformazioniToken informazioniTokenNormalizzate = null;
  559.                             if(listaEsiti!=null && !listaEsiti.isEmpty()) {
  560.                                 informazioniTokenNormalizzate = GestoreToken.normalizeInformazioniToken(listaEsiti);
  561.                                 informazioniTokenNormalizzate.setValid(true);
  562.                             }
  563.                             if(informazioniTokenNormalizzate==null && esitoDynamicDiscovery!=null && esitoDynamicDiscovery.getDynamicDiscovery()!=null) {
  564.                                 informazioniTokenNormalizzate = new InformazioniToken();
  565.                                 if(esitoPresenzaToken!=null) {
  566.                                     informazioniTokenNormalizzate.setToken(esitoPresenzaToken.getToken());
  567.                                 }
  568.                                 informazioniTokenNormalizzate.setDynamicDiscovery(esitoDynamicDiscovery.getDynamicDiscovery());
  569.                             }
  570.                             if(informazioniTokenNormalizzate!=null) {
  571.                                 
  572.                                 if(esitoDynamicDiscovery!=null) {
  573.                                     informazioniTokenNormalizzate.setDynamicDiscovery(esitoDynamicDiscovery.getDynamicDiscovery());
  574.                                 }
  575.                                 
  576.                                 this.pddContext.addObject(org.openspcoop2.pdd.core.token.Costanti.PDD_CONTEXT_TOKEN_INFORMAZIONI_NORMALIZZATE, informazioniTokenNormalizzate);
  577.                                 
  578.                                 this.transaction.setInformazioniToken(informazioniTokenNormalizzate);
  579.                             }
  580.                                                 
  581.                             this.msgDiag.mediumDebug("Gestione forward token ...");
  582.                             gestioneTokenEngine.forwardToken(datiInvocazione,esitoPresenzaToken,
  583.                                     esitoValidazioneToken, esitoIntrospectionToken, esitoUserInfoToken,
  584.                                     informazioniTokenNormalizzate);
  585.                             this.msgDiag.mediumDebug("Gestione forward token completata");
  586.                             
  587.                             this.msgDiag.logPersonalizzato("gestioneTokenCompletataConSuccesso");
  588.                         }
  589.                         else {
  590.                             this.msgDiag.logPersonalizzato("gestioneTokenCompletataSenzaRilevazioneToken");
  591.                         }               
  592.                     }
  593.                     
  594.                 } catch (Exception e) {
  595.                     
  596.                     this.msgDiag.addKeyword(CostantiPdD.KEY_ERRORE_PROCESSAMENTO, e.getMessage());
  597.                     this.msgDiag.logPersonalizzato("gestioneTokenFallita.erroreGenerico");
  598.                     this.logCore.error(gestioneTokenPrefix+"fallito, " + e.getMessage(),e);
  599.                     
  600.                     errore = ErroriIntegrazione.ERRORE_5XX_GENERICO_PROCESSAMENTO_MESSAGGIO.
  601.                             get5XX_ErroreProcessamento(gestioneTokenPrefix+"fallito, " + e.getMessage(),
  602.                                     CodiceErroreIntegrazione.CODICE_560_GESTIONE_TOKEN);
  603.                     eGestioneToken = e;
  604.                     
  605.                     integrationFunctionError = IntegrationFunctionError.INTERNAL_REQUEST_ERROR;
  606.                     
  607.                     fineGestione = true;
  608.                     
  609.                 }
  610.                 if (fineGestione) {
  611.                     
  612.                     this.openspcoopstate.releaseResource();
  613.         
  614.                     if (this.msgContext.isGestioneRisposta()) {
  615.                         if(errorMessageGestioneToken!=null) {
  616.                             this.msgContext.setMessageResponse(errorMessageGestioneToken);
  617.                         }
  618.                         else {
  619.                             if(CodiceErroreIntegrazione.CODICE_443_TOKEN_NON_PRESENTE.equals(errore.getCodiceErrore())){
  620.                                 if(integrationFunctionError==null) {
  621.                                     integrationFunctionError = IntegrationFunctionError.TOKEN_NOT_FOUND;
  622.                                 }
  623.                             }
  624.                             else if(CodiceErroreIntegrazione.CODICE_444_TOKEN_NON_VALIDO.equals(errore.getCodiceErrore())){
  625.                                 if(integrationFunctionError==null) {
  626.                                     integrationFunctionError = IntegrationFunctionError.TOKEN_INVALID;
  627.                                 }
  628.                             }
  629.                             else{
  630.                                 if(integrationFunctionError==null) {
  631.                                     integrationFunctionError = IntegrationFunctionError.INTERNAL_REQUEST_ERROR;
  632.                                 }
  633.                             }
  634.                             
  635.                             OpenSPCoop2Message errorOpenSPCoopMsg = (this.generatoreErrore.build(this.pddContext,integrationFunctionError,errore,
  636.                                     eGestioneToken,null));
  637.                             
  638.                             if(wwwAuthenticateErrorHeader!=null) {
  639.                                 errorOpenSPCoopMsg.forceTransportHeader(HttpConstants.AUTHORIZATION_RESPONSE_WWW_AUTHENTICATE, wwwAuthenticateErrorHeader);
  640.                             }
  641.                             
  642.                             this.msgContext.setMessageResponse(errorOpenSPCoopMsg);
  643.                         }
  644.                     }
  645.                     
  646.                     updateCredenzialiToken();
  647.                     
  648.                     return false;
  649.                     
  650.                 }
  651.             }finally {
  652.                 this.transaction.getTempiElaborazione().endToken();
  653.             }
  654.         }
  655.         
  656.         return true;
  657.         
  658.     }
  659.     
  660.     private void updateCredenzialiToken() {
  661.         
  662.         // Viene chiamato se la validazione fallisce
  663.         
  664.         if(OpenSPCoop2Properties.getInstance().isGestioneTokenSaveTokenAuthenticationInfoValidationFailed()) {
  665.             CredenzialiMittente credenzialiMittente = this.transaction.getCredenzialiMittente();
  666.             if(credenzialiMittente==null) {
  667.                 credenzialiMittente = new CredenzialiMittente();
  668.                 try {
  669.                     this.transaction.setCredenzialiMittente(credenzialiMittente);
  670.                 }catch(Exception e) {
  671.                     this.logCore.error("SetCredenzialiMittente error: "+e.getMessage(),e);
  672.                 }
  673.             }
  674.             InformazioniToken informazioniTokenNormalizzate = null;
  675.             if(this.pddContext.containsKey(org.openspcoop2.pdd.core.token.Costanti.PDD_CONTEXT_TOKEN_INFORMAZIONI_NORMALIZZATE)) {
  676.                 informazioniTokenNormalizzate = (InformazioniToken) this.pddContext.getObject(org.openspcoop2.pdd.core.token.Costanti.PDD_CONTEXT_TOKEN_INFORMAZIONI_NORMALIZZATE);
  677.             }
  678.             if(informazioniTokenNormalizzate!=null) {
  679.                 try {
  680.                     GestoreAutenticazione.updateCredenzialiToken(
  681.                             this.identitaPdD,
  682.                             RicezioneContenutiApplicativi.ID_MODULO, this.idTransazione, informazioniTokenNormalizzate, null, credenzialiMittente, 
  683.                             this.openspcoopstate, "RicezioneContenutiApplicativi.credenzialiToken", this.requestInfo,
  684.                             this.pddContext);
  685.                 }catch(Exception e) {
  686.                     this.logCore.error("updateCredenzialiToken error: "+e.getMessage(),e);
  687.                 }
  688.             }
  689.         }
  690.     }
  691. }
Created with JaCoCo 0.8.8.202204050719