RicezioneBusteGestioneToken.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.PortaApplicativa;
  26. import org.openspcoop2.core.config.PortaDelegata;
  27. import org.openspcoop2.core.id.IDPortaApplicativa;
  28. import org.openspcoop2.core.id.IDPortaDelegata;
  29. import org.openspcoop2.core.id.IDSoggetto;
  30. import org.openspcoop2.core.transazioni.utils.CredenzialiMittente;
  31. import org.openspcoop2.message.OpenSPCoop2Message;
  32. import org.openspcoop2.pdd.config.ConfigurazionePdDManager;
  33. import org.openspcoop2.pdd.config.OpenSPCoop2Properties;
  34. import org.openspcoop2.pdd.core.CostantiPdD;
  35. import org.openspcoop2.pdd.core.PdDContext;
  36. import org.openspcoop2.pdd.core.autenticazione.GestoreAutenticazione;
  37. import org.openspcoop2.pdd.core.handlers.InRequestContext;
  38. import org.openspcoop2.pdd.core.state.IOpenSPCoopState;
  39. import org.openspcoop2.pdd.core.token.GestoreToken;
  40. import org.openspcoop2.pdd.core.token.InformazioniToken;
  41. import org.openspcoop2.pdd.core.token.PolicyGestioneToken;
  42. import org.openspcoop2.pdd.core.token.pa.EsitoDynamicDiscoveryPortaApplicativa;
  43. import org.openspcoop2.pdd.core.token.pa.EsitoGestioneTokenPortaApplicativa;
  44. import org.openspcoop2.pdd.core.token.pa.EsitoPresenzaTokenPortaApplicativa;
  45. import org.openspcoop2.pdd.core.token.pa.GestioneToken;
  46. import org.openspcoop2.pdd.core.transazioni.Transaction;
  47. import org.openspcoop2.pdd.logger.MsgDiagnostico;
  48. import org.openspcoop2.pdd.logger.Tracciamento;
  49. import org.openspcoop2.pdd.services.error.RicezioneBusteExternalErrorGenerator;
  50. import org.openspcoop2.protocol.sdk.Busta;
  51. import org.openspcoop2.protocol.sdk.BustaRawContent;
  52. import org.openspcoop2.protocol.sdk.IProtocolFactory;
  53. import org.openspcoop2.protocol.sdk.constants.CodiceErroreCooperazione;
  54. import org.openspcoop2.protocol.sdk.constants.CodiceErroreIntegrazione;
  55. import org.openspcoop2.protocol.sdk.constants.ErroreCooperazione;
  56. import org.openspcoop2.protocol.sdk.constants.ErroreIntegrazione;
  57. import org.openspcoop2.protocol.sdk.constants.ErroriIntegrazione;
  58. import org.openspcoop2.protocol.sdk.constants.IntegrationFunctionError;
  59. import org.openspcoop2.protocol.sdk.state.RequestInfo;
  60. import org.openspcoop2.protocol.sdk.tracciamento.EsitoElaborazioneMessaggioTracciato;
  61. import org.openspcoop2.protocol.sdk.tracciamento.TracciamentoException;
  62. import org.openspcoop2.utils.transport.http.HttpConstants;
  63. import org.slf4j.Logger;

  65. /**
  66.  * RicezioneBusteGestioneToken
  67.  * 
  68.  * @author Poli Andrea (apoli@link.it)
  69.  * @author $Author$
  70.  * @version $Rev$, $Date$
  71.  */
  72. public class RicezioneBusteGestioneToken {

  74.     private MsgDiagnostico msgDiag;
  75.     private Logger logCore;
  76.     private Tracciamento tracciamento;
  77.     private String correlazioneApplicativa;
  78.     private BustaRawContent<?> soapHeaderElement;
  79.     private Busta bustaRichiesta;
  80.     
  81.     private PortaApplicativa pa;
  82.     private IDPortaApplicativa idPA;
  83.     private PortaDelegata pd;
  84.     private IDPortaDelegata idPD;
  85.     
  86.     private OpenSPCoop2Message requestMessage;
  87.     
  88.     private boolean asincronoSimmetricoRisposta;
  89.     
  90.     private RicezioneBusteContext msgContext;
  91.     private RicezioneBusteExternalErrorGenerator generatoreErrore;
  92.     private InRequestContext inRequestContext;
  93.     
  94.     private ConfigurazionePdDManager configurazionePdDReader;
  95.     
  96.     private PdDContext pddContext;
  97.     private String idTransazione;
  98.     private IOpenSPCoopState openspcoopstate;
  99.     private Transaction transaction;
  100.     private RequestInfo requestInfo;
  101.     
  102.     private IProtocolFactory<?> protocolFactory;
  103.     
  104.     private RicezioneBusteParametriGenerazioneBustaErrore parametriGenerazioneBustaErrore;
  105.     private RicezioneBusteParametriInvioBustaErrore parametriInvioBustaErrore;
  106.     
  107.     private IDSoggetto identitaPdD;
  108.     
  109.     public RicezioneBusteGestioneToken(MsgDiagnostico msgDiag, Logger logCore,
  110.             Tracciamento tracciamento, String correlazioneApplicativa, BustaRawContent<?> soapHeaderElement, Busta bustaRichiesta,
  111.             PortaApplicativa pa, IDPortaApplicativa idPA, PortaDelegata pd, IDPortaDelegata idPD,
  112.             OpenSPCoop2Message requestMessage,
  113.             boolean asincronoSimmetricoRisposta,
  114.             RicezioneBusteContext msgContext, RicezioneBusteExternalErrorGenerator generatoreErrore, InRequestContext inRequestContext,
  115.             ConfigurazionePdDManager configurazionePdDReader,
  116.             PdDContext pddContext, String idTransazione,
  117.             IOpenSPCoopState openspcoopstate, Transaction transaction, RequestInfo requestInfo,
  118.             IProtocolFactory<?> protocolFactory,
  119.             IDSoggetto identitaPdD,
  120.             RicezioneBusteParametriGenerazioneBustaErrore parametriGenerazioneBustaErrore, RicezioneBusteParametriInvioBustaErrore parametriInvioBustaErrore) {
  121.         this.msgDiag = msgDiag;
  122.         this.logCore = logCore;
  123.         
  124.         this.tracciamento = tracciamento;
  125.         this.correlazioneApplicativa = correlazioneApplicativa;
  126.         this.soapHeaderElement = soapHeaderElement;
  127.         this.bustaRichiesta = bustaRichiesta;
  128.         
  129.         this.pa = pa;
  130.         this.idPA = idPA;
  131.         this.pd = pd;
  132.         this.idPD = idPD;
  133.         
  134.         this.requestMessage = requestMessage;
  135.         
  136.         this.asincronoSimmetricoRisposta = asincronoSimmetricoRisposta;
  137.         
  138.         this.msgContext = msgContext;
  139.         this.generatoreErrore = generatoreErrore;
  140.         this.inRequestContext = inRequestContext;
  141.         
  142.         this.configurazionePdDReader = configurazionePdDReader;
  143.         
  144.         this.pddContext = pddContext;
  145.         this.idTransazione = idTransazione;
  146.         this.openspcoopstate = openspcoopstate;
  147.         this.transaction = transaction;
  148.         this.requestInfo = requestInfo; 
  149.         
  150.         this.protocolFactory = protocolFactory;
  151.         
  152.         this.identitaPdD = identitaPdD;
  153.         
  154.         this.parametriGenerazioneBustaErrore = parametriGenerazioneBustaErrore;
  155.         this.parametriInvioBustaErrore = parametriInvioBustaErrore;
  156.     }
  157.     
  158.     // Result
  159.     private GestioneTokenAutenticazione gestioneTokenAutenticazione = null;
  160.     private String token = null;
  161.     private String tipoGestioneToken = null;
  162.     
  163.     public GestioneTokenAutenticazione getGestioneTokenAutenticazione() {
  164.         return this.gestioneTokenAutenticazione;
  165.     }
  166.     public String getToken() {
  167.         return this.token;
  168.     }
  169.     public String getTipoGestioneToken() {
  170.         return this.tipoGestioneToken;
  171.     }
  172.     
  173.     public boolean process() throws TracciamentoException {
  174.         this.msgDiag.mediumDebug("GestioneToken...");
  175.         try {
  176.             if(this.pa!=null){
  177.                 this.tipoGestioneToken = this.configurazionePdDReader.getGestioneToken(this.pa);
  178.                 if(this.pa.getGestioneToken()!=null) {
  179.                     this.gestioneTokenAutenticazione = this.pa.getGestioneToken().getAutenticazione();
  180.                 }
  181.             }
  182.             else{
  183.                 this.tipoGestioneToken = this.configurazionePdDReader.getGestioneToken(this.pd);
  184.                 if(this.pd.getGestioneToken()!=null) {
  185.                     this.gestioneTokenAutenticazione = this.pd.getGestioneToken().getAutenticazione();
  186.                 }
  187.             }
  188.         }catch(Exception exception){
  189.             // ignore
  190.         }
  191.         
  192.         String gestioneTokenPrefix = "processo di gestione token ["+ this.tipoGestioneToken + "] ";
  193.         
  194.         this.msgContext.getIntegrazione().setTipoGestioneToken(this.tipoGestioneToken);
  195.         if (this.tipoGestioneToken == null || this.asincronoSimmetricoRisposta) {

  197.             if(!this.asincronoSimmetricoRisposta) {
  198.                 this.msgDiag.logPersonalizzato("gestioneTokenDisabilitata");
  199.             }
  200.             
  201.         } else {

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

  745.         }
  746.         
  747.         return true;
  748.     }
  749.     
  750.     private void updateCredenzialiToken() {
  751.         
  752.         // Viene chiamato se la validazione fallisce
  753.         
  754.         if(OpenSPCoop2Properties.getInstance().isGestioneTokenSaveTokenAuthenticationInfoValidationFailed()) {
  755.             CredenzialiMittente credenzialiMittente = this.transaction.getCredenzialiMittente();
  756.             if(credenzialiMittente==null) {
  757.                 credenzialiMittente = new CredenzialiMittente();
  758.                 try {
  759.                     this.transaction.setCredenzialiMittente(credenzialiMittente);
  760.                 }catch(Exception e) {
  761.                     this.logCore.error("SetCredenzialiMittente error: "+e.getMessage(),e);
  762.                 }
  763.             }
  764.             InformazioniToken informazioniTokenNormalizzate = null;
  765.             if(this.pddContext.containsKey(org.openspcoop2.pdd.core.token.Costanti.PDD_CONTEXT_TOKEN_INFORMAZIONI_NORMALIZZATE)) {
  766.                 informazioniTokenNormalizzate = (InformazioniToken) this.pddContext.getObject(org.openspcoop2.pdd.core.token.Costanti.PDD_CONTEXT_TOKEN_INFORMAZIONI_NORMALIZZATE);
  767.             }
  768.             if(informazioniTokenNormalizzate!=null) {
  769.                 try {
  770.                     GestoreAutenticazione.updateCredenzialiToken(
  771.                             this.identitaPdD,
  772.                             RicezioneBuste.ID_MODULO, this.idTransazione, informazioniTokenNormalizzate, null, credenzialiMittente, 
  773.                             this.openspcoopstate, "RicezioneBuste.credenzialiToken", this.requestInfo,
  774.                             this.pddContext);
  775.                 }catch(Exception e) {
  776.                     this.logCore.error("updateCredenzialiToken error: "+e.getMessage(),e);
  777.                 }
  778.             }
  779.         }
  780.     }
  781. }
Created with JaCoCo 0.8.8.202204050719