ModIValidazioneSintatticaRest.java

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

  21. package org.openspcoop2.protocol.modipa.validator;

  23. import java.io.ByteArrayOutputStream;
  24. import java.security.cert.X509Certificate;
  25. import java.util.Date;
  26. import java.util.HashMap;
  27. import java.util.Iterator;
  28. import java.util.List;
  29. import java.util.Map;

  31. import org.apache.commons.lang.StringUtils;
  32. import org.openspcoop2.core.config.PortaApplicativa;
  33. import org.openspcoop2.core.constants.CostantiDB;
  34. import org.openspcoop2.core.id.IDPortaApplicativa;
  35. import org.openspcoop2.core.id.IDSoggetto;
  36. import org.openspcoop2.core.registry.AccordoServizioParteComune;
  37. import org.openspcoop2.core.registry.Resource;
  38. import org.openspcoop2.message.OpenSPCoop2Message;
  39. import org.openspcoop2.message.constants.MessageRole;
  40. import org.openspcoop2.message.constants.MessageType;
  41. import org.openspcoop2.message.constants.ServiceBinding;
  42. import org.openspcoop2.pdd.core.dynamic.DynamicMapBuilderUtils;
  43. import org.openspcoop2.pdd.core.dynamic.DynamicUtils;
  44. import org.openspcoop2.pdd.core.keystore.RemoteStoreProvider;
  45. import org.openspcoop2.pdd.core.token.Costanti;
  46. import org.openspcoop2.pdd.core.token.parser.Claims;
  47. import org.openspcoop2.pdd.core.token.parser.TokenUtils;
  48. import org.openspcoop2.pdd.logger.MsgDiagnostico;
  49. import org.openspcoop2.protocol.modipa.config.ModIAuditClaimConfig;
  50. import org.openspcoop2.protocol.modipa.config.ModIAuditConfig;
  51. import org.openspcoop2.protocol.modipa.config.ModIProperties;
  52. import org.openspcoop2.protocol.modipa.constants.ModICostanti;
  53. import org.openspcoop2.protocol.modipa.constants.ModIHeaderType;
  54. import org.openspcoop2.protocol.modipa.utils.ModISecurityConfig;
  55. import org.openspcoop2.protocol.modipa.utils.ModITruststoreConfig;
  56. import org.openspcoop2.protocol.modipa.utils.ModIUtilities;
  57. import org.openspcoop2.protocol.sdk.Busta;
  58. import org.openspcoop2.protocol.sdk.Context;
  59. import org.openspcoop2.protocol.sdk.Eccezione;
  60. import org.openspcoop2.protocol.sdk.IProtocolFactory;
  61. import org.openspcoop2.protocol.sdk.ProtocolException;
  62. import org.openspcoop2.protocol.sdk.RestMessageSecurityToken;
  63. import org.openspcoop2.protocol.sdk.SecurityToken;
  64. import org.openspcoop2.protocol.sdk.constants.CodiceErroreCooperazione;
  65. import org.openspcoop2.protocol.sdk.state.IState;
  66. import org.openspcoop2.protocol.sdk.state.RequestInfo;
  67. import org.openspcoop2.protocol.sdk.validator.ValidazioneUtils;
  68. import org.openspcoop2.security.message.MessageSecurityContext;
  69. import org.openspcoop2.security.message.MessageSecurityContextParameters;
  70. import org.openspcoop2.security.message.constants.SecurityConstants;
  71. import org.openspcoop2.security.message.engine.MessageSecurityContext_impl;
  72. import org.openspcoop2.security.message.jose.MessageSecurityReceiver_jose;
  73. import org.openspcoop2.utils.certificate.CertificateInfo;
  74. import org.openspcoop2.utils.certificate.remote.RemoteKeyType;
  75. import org.openspcoop2.utils.date.DateUtils;
  76. import org.openspcoop2.utils.digest.DigestEncoding;
  77. import org.openspcoop2.utils.json.JSONUtils;
  78. import org.openspcoop2.utils.transport.TransportUtils;
  79. import org.openspcoop2.utils.transport.http.HttpConstants;
  80. import org.openspcoop2.utils.transport.http.HttpUtilities;
  81. import org.slf4j.Logger;

  83. import com.fasterxml.jackson.databind.JsonNode;
  84. import com.fasterxml.jackson.databind.node.ArrayNode;
  85. import com.fasterxml.jackson.databind.node.ObjectNode;
  86. import com.fasterxml.jackson.databind.node.TextNode;

  88. /**
  89.  * ModIValidazioneSintatticaRest
  90.  *
  91.  * @author Poli Andrea (apoli@link.it)
  92.  * @author $Author$
  93.  * @version $Rev$, $Date$
  94.  */
  95. public class ModIValidazioneSintatticaRest extends AbstractModIValidazioneSintatticaCommons{

  97.     public ModIValidazioneSintatticaRest(Logger log, IState state, Context context, IProtocolFactory<?> factory, RequestInfo requestInfo, 
  98.             ModIProperties modiProperties, ValidazioneUtils validazioneUtils) {
  99.         super(log, state, context, factory, requestInfo, modiProperties, validazioneUtils);
  100.     }
  101.     
  102.     private void logError(String msg) {
  103.         this.log.error(msg);
  104.     }
  105.     private void logError(String msg, Exception e) {
  106.         this.log.error(msg,e);
  107.     }
  108.     
  109.     public void validateSyncInteractionProfile(OpenSPCoop2Message msg, boolean request,
  110.             List<Eccezione> erroriValidazione) throws ProtocolException {
  111.         
  112.         if(!request) {
  113.             
  114.             String returnCode = null;
  115.             int returnCodeInt = -1;
  116.             if(!request && msg.getTransportResponseContext()!=null) {
  117.                 returnCode = msg.getTransportResponseContext().getCodiceTrasporto();
  118.                 if(returnCode!=null) {
  119.                     try {
  120.                         returnCodeInt = Integer.valueOf(returnCode);
  121.                     }catch(Exception e) {
  122.                         // ignore
  123.                     }
  124.                 }
  125.             }
  126.             
  127.             Integer [] returnCodeAttesi = this.modiProperties.getRestBloccanteHttpStatus();
  128.             
  129.             // Fix: il controllo deve essere fatto solo per i codici che non rientrano in 4xx e 5xx
  130.             boolean is4xx5xx = (returnCodeInt>=400) && (returnCodeInt<=599);
  131.             
  132.             if(!is4xx5xx && returnCodeAttesi!=null) {
  133.                 boolean found = false;
  134.                 for (Integer integer : returnCodeAttesi) {
  135.                     if(integer.intValue() == ModICostanti.MODIPA_PROFILO_INTERAZIONE_HTTP_CODE_2XX_INT_VALUE) {
  136.                         if((returnCodeInt >= 200) && (returnCodeInt<=299) ) {
  137.                             found = true;
  138.                         }
  139.                     }
  140.                     else if(integer.intValue() == returnCodeInt) {
  141.                         found = true;
  142.                     }
  143.                     if(found) {
  144.                         break;
  145.                     }
  146.                 }
  147.                 if(!found) {
  148.                     StringBuilder sb = new StringBuilder();
  149.                     for (Integer integer : returnCodeAttesi) {
  150.                         
  151.                         if(integer.intValue() == ModICostanti.MODIPA_PROFILO_INTERAZIONE_HTTP_CODE_2XX_INT_VALUE) {
  152.                             sb = new StringBuilder();
  153.                             sb.append("2xx");
  154.                             break;
  155.                         }
  156.                         
  157.                         if(sb.length()>0) {
  158.                             sb.append(",");
  159.                         }
  160.                         sb.append(integer.intValue());
  161.                     }
  162.                     erroriValidazione.add(this.validazioneUtils.newEccezioneValidazione(CodiceErroreCooperazione.PROFILO_TRASMISSIONE, 
  163.                             "HTTP Status '"+returnCodeInt+"' differente da quello atteso per il profilo bloccante (atteso: "+sb.toString()+")"));
  164.                 }
  165.             }
  166.         }
  167.         
  168.     }
  169.     
  170.     private String getErrorHeaderHttpPrefix(String hdr) {
  171.         return "Header HTTP '"+hdr+"'";
  172.     }
  173.     private String getErrorHeaderHttpNonPresente(String hdr) {
  174.         return getErrorHeaderHttpPrefix(hdr)+" non presente";
  175.     }
  176.     private String getErrorHeaderHttpPresentePiuVolte(String hdr) {
  177.         return getErrorHeaderHttpPrefix(hdr)+" presente più volte";
  178.     }
  179.     
  180.     static String getErroreTokenSenzaClaim(String c) {
  181.         return "Token senza claim '"+c+"'";
  182.     } 
  183.     static String getErroreTokenClaimNonValido(String c, Exception e) {
  184.         return "Token con claim '"+c+"' non valido: "+e.getMessage();
  185.     }
  186.     
  187.     public void validateAsyncInteractionProfile(OpenSPCoop2Message msg, boolean request, String asyncInteractionType, String asyncInteractionRole, 
  188.             AccordoServizioParteComune apiContenenteRisorsa, String azione,
  189.             Busta busta, List<Eccezione> erroriValidazione,
  190.             String replyTo) throws ProtocolException {
  191.                 
  192.         String correlationIdHeader = this.modiProperties.getRestCorrelationIdHeader();
  193.         String correlationId = null;
  194.         if(msg!=null) {
  195.             if(request && msg.getTransportRequestContext()!=null) {
  196.                 correlationId = msg.getTransportRequestContext().getHeaderFirstValue(correlationIdHeader);
  197.             }
  198.             else if(!request && msg.getTransportResponseContext()!=null) {
  199.                 correlationId = msg.getTransportResponseContext().getHeaderFirstValue(correlationIdHeader);
  200.             }
  201.         }
  202.         
  203.         String replyToHeader = this.modiProperties.getRestReplyToHeader();
  204.         String replyToAddress = null;
  205.         if(msg!=null) {
  206.             if(request && msg.getTransportRequestContext()!=null) {
  207.                 replyToAddress = msg.getTransportRequestContext().getHeaderFirstValue(replyToHeader);
  208.             }
  209.             else if(!request && msg.getTransportResponseContext()!=null) {
  210.                 replyToAddress = msg.getTransportResponseContext().getHeaderFirstValue(replyToHeader);
  211.             }
  212.         }
  213.         
  214.         String locationHeader = this.modiProperties.getRestLocationHeader();
  215.         String location = null;
  216.         if(msg!=null) {
  217.             if(request && msg.getTransportRequestContext()!=null) {
  218.                 location = msg.getTransportRequestContext().getHeaderFirstValue(locationHeader);
  219.             }
  220.             else if(!request && msg.getTransportResponseContext()!=null) {
  221.                 location = msg.getTransportResponseContext().getHeaderFirstValue(locationHeader);
  222.             }
  223.         }
  224.         
  225.         if(replyToAddress!=null) {
  226.             busta.addProperty(ModICostanti.MODIPA_BUSTA_EXT_PROFILO_INTERAZIONE_ASINCRONA_REPLY_TO, replyToAddress);
  227.         }
  228.         if(correlationId!=null) {
  229.             busta.addProperty(ModICostanti.MODIPA_BUSTA_EXT_PROFILO_INTERAZIONE_ASINCRONA_ID_CORRELAZIONE, correlationId);
  230.             if(correlationId.length()<=255) {
  231.                 busta.setCollaborazione(correlationId);
  232.             }
  233.         }
  234.         
  235.         String returnCode = null;
  236.         int returnCodeInt = -1;
  237.         if(!request && msg.getTransportResponseContext()!=null) {
  238.             returnCode = msg.getTransportResponseContext().getCodiceTrasporto();
  239.             if(returnCode!=null) {
  240.                 try {
  241.                     returnCodeInt = Integer.valueOf(returnCode);
  242.                 }catch(Exception e) {
  243.                     // ignore
  244.                 }
  245.             }
  246.         }
  247.         
  248.         // Fix: il controllo deve essere fatto solo per i codici che non rientrano in 4xx e 5xx
  249.         boolean is4xx5xx = false;
  250.         if(!request) {
  251.             is4xx5xx = (returnCodeInt>=400) && (returnCodeInt<=599);
  252.         }
  253.         
  254.         Integer [] returnCodeAttesi = null;
  255.         
  256.         if(!is4xx5xx && asyncInteractionType!=null) {
  257.             if(ModICostanti.MODIPA_PROFILO_INTERAZIONE_ASINCRONA_VALUE_PUSH.equals(asyncInteractionType)) {
  258.                 if(ModICostanti.MODIPA_PROFILO_INTERAZIONE_ASINCRONA_RUOLO_VALUE_RICHIESTA.equals(asyncInteractionRole)) {
  259.                     if(request) {
  260.                         if(replyToAddress==null || "".equals(replyToAddress)) {
  261.                             erroriValidazione.add(this.validazioneUtils.newEccezioneValidazione(CodiceErroreCooperazione.SERVIZIO_CORRELATO_NON_PRESENTE, 
  262.                                     getErrorHeaderHttpNonPresente(replyToHeader)));
  263.                             return;
  264.                         }
  265.                         if(this.modiProperties.isRestSecurityTokenPushReplyToUpdateInErogazione()) {
  266.                             if(msg.getTransportRequestContext()!=null) {
  267.                                 msg.getTransportRequestContext().removeHeader(replyToHeader); // rimuovo se già esiste
  268.                             }
  269.                             msg.forceTransportHeader(replyToHeader, replyTo);
  270.                         }
  271.                     }
  272.                     else {
  273.                         if(correlationId==null || "".equals(correlationId)) {
  274.                             erroriValidazione.add(this.validazioneUtils.newEccezioneValidazione(CodiceErroreCooperazione.COLLABORAZIONE_NON_PRESENTE, 
  275.                                     getErrorHeaderHttpNonPresente(correlationIdHeader)));
  276.                             return;
  277.                         }
  278.                         returnCodeAttesi = this.modiProperties.getRestNonBloccantePushRequestHttpStatus();
  279.                     }
  280.                 }
  281.                 else {
  282.                     if(request) {
  283.                         if(correlationId==null || "".equals(correlationId)) {
  284.                             erroriValidazione.add(this.validazioneUtils.newEccezioneValidazione(CodiceErroreCooperazione.COLLABORAZIONE_NON_PRESENTE, 
  285.                                     getErrorHeaderHttpNonPresente(correlationIdHeader)));
  286.                             return;
  287.                         }
  288.                     }
  289.                     else {
  290.                         returnCodeAttesi = this.modiProperties.getRestNonBloccantePushResponseHttpStatus();
  291.                     }
  292.                 }
  293.             }
  294.             else {
  295.                 // pull
  296.                 if(request) {
  297.                     
  298.                     // Flusso di richiesta
  299.                     
  300.                     if(ModICostanti.MODIPA_PROFILO_INTERAZIONE_ASINCRONA_RUOLO_VALUE_RICHIESTA_STATO.equals(asyncInteractionRole) ||
  301.                             ModICostanti.MODIPA_PROFILO_INTERAZIONE_ASINCRONA_RUOLO_VALUE_RISPOSTA.equals(asyncInteractionRole)) {
  302.                     
  303.                         String urlInvocata = msg.getTransportRequestContext().getFunctionParameters();
  304.                         if(urlInvocata!=null && !"".equals(urlInvocata)) {
  305.                             
  306.                             String resourcePathAzione = null;
  307.                             for (Resource r : apiContenenteRisorsa.getResourceList()) {
  308.                                 if(r.getNome().equals(azione)) {
  309.                                     resourcePathAzione = r.getPath();
  310.                                     break;
  311.                                 }
  312.                             }
  313.                             
  314.                             if(!urlInvocata.startsWith("/")) {
  315.                                 urlInvocata = "/" + urlInvocata;
  316.                             }
  317.                             String correlationIdExtracted = ModIUtilities.extractCorrelationIdFromLocation(resourcePathAzione, urlInvocata, false, this.log);
  318.                             if(correlationIdExtracted!=null && correlationIdExtracted.length()<=255) {
  319.                                 busta.setCollaborazione(correlationIdExtracted);
  320.                             }
  321.                         }
  322.                         
  323.                     }
  324.                     
  325.                     
  326.                 }
  327.                 else {
  328.                     
  329.                     // Flusso di risposta
  330.                     
  331.                     if(ModICostanti.MODIPA_PROFILO_INTERAZIONE_ASINCRONA_RUOLO_VALUE_RICHIESTA.equals(asyncInteractionRole)) {
  332.                         if(location==null || "".equals(location)) {
  333.                             erroriValidazione.add(this.validazioneUtils.newEccezioneValidazione(CodiceErroreCooperazione.SERVIZIO_CORRELATO_NON_PRESENTE, 
  334.                                     getErrorHeaderHttpNonPresente(locationHeader)));
  335.                             return;
  336.                         }
  337.                         busta.addProperty(ModICostanti.MODIPA_BUSTA_EXT_PROFILO_INTERAZIONE_ASINCRONA_LOCATION, location);
  338.                         
  339.                         String correlationIdExtracted = ModIUtilities.extractCorrelationId(location, apiContenenteRisorsa, azione, asyncInteractionRole, this.log);
  340.                         if(correlationIdExtracted!=null && correlationIdExtracted.length()<=255) {
  341.                             busta.setCollaborazione(correlationIdExtracted);
  342.                         }
  343.                         
  344.                         returnCodeAttesi = this.modiProperties.getRestNonBloccantePullRequestHttpStatus();
  345.                     }
  346.                     else if(ModICostanti.MODIPA_PROFILO_INTERAZIONE_ASINCRONA_RUOLO_VALUE_RICHIESTA_STATO.equals(asyncInteractionRole)) {
  347.                         
  348.                         Integer [] returnCodeResourceReady = this.modiProperties.getRestNonBloccantePullRequestStateOkHttpStatus();
  349.                         boolean isReady = false;
  350.                         for (Integer integer : returnCodeResourceReady) {
  351.                             if(integer.intValue() == returnCodeInt) {
  352.                                 isReady = true;
  353.                                 break;
  354.                             }
  355.                         }
  356.                         
  357.                         if(isReady) {
  358.                             if(location==null || "".equals(location)) {
  359.                                 erroriValidazione.add(this.validazioneUtils.newEccezioneValidazione(CodiceErroreCooperazione.SERVIZIO_CORRELATO_NON_PRESENTE, 
  360.                                         getErrorHeaderHttpNonPresente(locationHeader)));
  361.                                 return;
  362.                             }
  363.                             busta.addProperty(ModICostanti.MODIPA_BUSTA_EXT_PROFILO_INTERAZIONE_ASINCRONA_LOCATION, location);
  364.                             
  365.                             String correlationIdExtracted = ModIUtilities.extractCorrelationId(location, apiContenenteRisorsa, azione, asyncInteractionRole, this.log);
  366.                             if(correlationIdExtracted!=null && correlationIdExtracted.length()<=255) {
  367.                                 busta.setCollaborazione(correlationIdExtracted);
  368.                             }
  369.                             
  370.                             returnCodeAttesi = returnCodeResourceReady;
  371.                         }
  372.                         else {
  373.                             Integer [] returnCodeAttesiNotReady = this.modiProperties.getRestNonBloccantePullRequestStateNotReadyHttpStatus();
  374.                             returnCodeAttesi = new Integer[returnCodeResourceReady.length+returnCodeAttesiNotReady.length];
  375.                             int i = 0;
  376.                             for (int j=0; j < returnCodeAttesiNotReady.length; j++) {
  377.                                 returnCodeAttesi[i] = returnCodeAttesiNotReady[j];
  378.                                 i++;
  379.                             }
  380.                             for (int j=0; j < returnCodeResourceReady.length; j++) {
  381.                                 returnCodeAttesi[i] = returnCodeResourceReady[j];
  382.                                 i++;
  383.                             }
  384.                         }
  385.                         
  386.                     }
  387.                     else {
  388.                         returnCodeAttesi = this.modiProperties.getRestNonBloccantePullResponseHttpStatus();
  389.                     }
  390.                 }
  391.             }
  392.         }
  393.         
  394.         if(returnCodeAttesi!=null) {
  395.             boolean found = false;
  396.             for (Integer integer : returnCodeAttesi) {
  397.                 if(integer.intValue() == returnCodeInt) {
  398.                     found = true;
  399.                     break;
  400.                 }
  401.             }
  402.             if(!found) {
  403.                 StringBuilder sb = new StringBuilder();
  404.                 for (Integer integer : returnCodeAttesi) {
  405.                     if(sb.length()>0) {
  406.                         sb.append(",");
  407.                     }
  408.                     sb.append(integer.intValue());
  409.                 }
  410.                 erroriValidazione.add(this.validazioneUtils.newEccezioneValidazione(CodiceErroreCooperazione.PROFILO_TRASMISSIONE, 
  411.                         "HTTP Status '"+returnCodeInt+"' differente da quello atteso per il profilo non bloccante '"+asyncInteractionType+"' con ruolo '"+asyncInteractionRole+"' (atteso: "+sb.toString()+")"));
  412.             }
  413.         }
  414.     }
  415.     
  416.     public String validateSecurityProfile(OpenSPCoop2Message msg, boolean request, String securityMessageProfile, boolean useKIDtokenHeader, String headerTokenRest, 
  417.             boolean corniceSicurezza, String patternCorniceSicurezza, String schemaCorniceSicurezza, 
  418.             boolean includiRequestDigest, 
  419.             Busta busta, List<Eccezione> erroriValidazione,
  420.             ModITruststoreConfig trustStoreCertificati, ModITruststoreConfig trustStoreSsl, ModISecurityConfig securityConfig,
  421.             boolean buildSecurityTokenInRequest, ModIHeaderType headerType, boolean integritaCustom, boolean securityHeaderObbligatorio,
  422.             Map<String, Object> dynamicMapParameter, Busta datiRichiesta,
  423.             IDSoggetto idSoggetto, MsgDiagnostico msgDiag) throws ProtocolException {
  424.         
  425.         if(msg==null) {
  426.             throw new ProtocolException("Param msg is null");
  427.         }
  428.                 
  429.         boolean bufferMessageReadOnly = this.modiProperties.isReadByPathBufferEnabled();
  430.         String idTransazione = null;
  431.         if(this.context!=null) {
  432.             idTransazione = (String)this.context.getObject(org.openspcoop2.core.constants.Costanti.ID_TRANSAZIONE);
  433.         }
  434.         
  435.         String securityTokenHeader = headerTokenRest;
  436.         List<String> securityTokens = null;
  437.         if(request && msg.getTransportRequestContext()!=null) {
  438.             securityTokens = msg.getTransportRequestContext().getHeaderValues(securityTokenHeader);
  439.         }
  440.         else if(!request && msg.getTransportResponseContext()!=null) {
  441.             securityTokens = msg.getTransportResponseContext().getHeaderValues(securityTokenHeader);
  442.         }
  443.         String securityToken = null;
  444.         if(securityTokens!=null && !securityTokens.isEmpty()) {
  445.             securityToken = securityTokens.get(0);
  446.         }
  447.         
  448.         
  449.         boolean attesoSecurityHeader = securityHeaderObbligatorio;
  450.         if(!request) {
  451.             try {
  452.                 if(msg.isFault()) {
  453.                     attesoSecurityHeader = false;
  454.                 }
  455.             }catch(Exception e) {
  456.                 throw new ProtocolException(e.getMessage(),e);
  457.             }
  458.         }
  459.         
  460.         if(securityToken==null || "".equals(securityToken)) {
  461.             if(attesoSecurityHeader) {
  462.                 erroriValidazione.add(this.validazioneUtils.newEccezioneValidazione(CodiceErroreCooperazione.SICUREZZA_TOKEN_NON_PRESENTE, 
  463.                         getErrorHeaderHttpNonPresente(securityTokenHeader)));
  464.             }
  465.             return null;
  466.         }
  467.         if(securityTokens.size()>1) {
  468.             if(attesoSecurityHeader) {
  469.                 erroriValidazione.add(this.validazioneUtils.newEccezioneValidazione(CodiceErroreCooperazione.SICUREZZA_TOKEN_PRESENTE_PIU_VOLTE, 
  470.                         getErrorHeaderHttpPresentePiuVolte(securityTokenHeader)));
  471.             }
  472.             return null;
  473.         }
  474.         
  475.         if(busta!=null && integritaCustom) {
  476.             busta.addProperty(ModICostanti.MODIPA_BUSTA_EXT_PROFILO_SICUREZZA_MESSAGGIO_CUSTOM_HEADER,headerTokenRest);
  477.         }
  478.         
  479.         String token = securityToken;
  480.         if(HttpConstants.AUTHORIZATION.equalsIgnoreCase(securityTokenHeader)) {
  481.             if(request) {
  482.                 if(msg.getTransportRequestContext()==null || msg.getTransportRequestContext().getCredential()==null) {
  483.                     erroriValidazione.add(this.validazioneUtils.newEccezioneValidazione(CodiceErroreCooperazione.SICUREZZA_TOKEN_NON_PRESENTE, 
  484.                             getErrorHeaderHttpNonPresente(HttpConstants.AUTHORIZATION)));
  485.                     return null;
  486.                 }
  487.                 if(msg.getTransportRequestContext().getCredential().getBearerToken()==null) {
  488.                     if(msg.getTransportRequestContext().getCredential().getUsername()!=null) {
  489.                         erroriValidazione.add(this.validazioneUtils.newEccezioneValidazione(CodiceErroreCooperazione.SICUREZZA_TOKEN_NON_PRESENTE, 
  490.                                 getErrorHeaderHttpPrefix(HttpConstants.AUTHORIZATION)+" non presente con prefisso '"+HttpConstants.AUTHORIZATION_PREFIX_BEARER+"'"));
  491.                         return null;
  492.                     }
  493.                     else {
  494.                         erroriValidazione.add(this.validazioneUtils.newEccezioneValidazione(CodiceErroreCooperazione.SICUREZZA_TOKEN_NON_PRESENTE, 
  495.                                 getErrorHeaderHttpNonPresente(HttpConstants.AUTHORIZATION)));
  496.                         return null;
  497.                     }
  498.                 }
  499.                 token = msg.getTransportRequestContext().getCredential().getBearerToken();
  500.             }
  501.             else {
  502.                 if(token.toLowerCase().startsWith(HttpConstants.AUTHORIZATION_PREFIX_BEARER.toLowerCase())){
  503.                     token = token.substring(HttpConstants.AUTHORIZATION_PREFIX_BEARER.length());
  504.                 }
  505.                 else {
  506.                     if(token.toLowerCase().startsWith(HttpConstants.AUTHORIZATION_PREFIX_BASIC.toLowerCase())){
  507.                         if(attesoSecurityHeader) {
  508.                             erroriValidazione.add(this.validazioneUtils.newEccezioneValidazione(CodiceErroreCooperazione.SICUREZZA_TOKEN_NON_PRESENTE, 
  509.                                     getErrorHeaderHttpPrefix(HttpConstants.AUTHORIZATION)+" non presente con prefisso '"+HttpConstants.AUTHORIZATION_PREFIX_BEARER+"'"));
  510.                         }
  511.                         return null;
  512.                     }
  513.                     else {
  514.                         if(attesoSecurityHeader) {
  515.                             erroriValidazione.add(this.validazioneUtils.newEccezioneValidazione(CodiceErroreCooperazione.SICUREZZA_TOKEN_NON_PRESENTE, 
  516.                                     getErrorHeaderHttpNonPresente(HttpConstants.AUTHORIZATION)));
  517.                         }
  518.                         return null;
  519.                     }
  520.                 }
  521.             }
  522.         }
  523.         
  524.         
  525.         boolean integritaX509 = false;
  526.         if(ModICostanti.MODIPA_PROFILO_SICUREZZA_MESSAGGIO_VALUE_IDAM0301.equals(securityMessageProfile) ||
  527.                 ModICostanti.MODIPA_PROFILO_SICUREZZA_MESSAGGIO_VALUE_IDAM0302.equals(securityMessageProfile)) {
  528.             integritaX509 = true;
  529.         }
  530.         boolean integritaKid = false;
  531.         if(ModICostanti.MODIPA_PROFILO_SICUREZZA_MESSAGGIO_VALUE_IDAM0401.equals(securityMessageProfile) ||
  532.                 ModICostanti.MODIPA_PROFILO_SICUREZZA_MESSAGGIO_VALUE_IDAM0402.equals(securityMessageProfile)) {
  533.             integritaKid = true;
  534.         }
  535.         boolean integrita = integritaX509 || integritaKid;
  536.         
  537.         
  538.         boolean tokenAudit = corniceSicurezza && !CostantiDB.MODIPA_PROFILO_SICUREZZA_MESSAGGIO_CORNICE_SICUREZZA_PATTERN_OLD.equals(patternCorniceSicurezza) && schemaCorniceSicurezza!=null;
  539.                 
  540.         boolean apiSoap = ServiceBinding.SOAP.equals(msg.getServiceBinding());
  541.         

  543.         String prefix = "";
  544.         boolean headerDuplicati = headerType.isHeaderDuplicati();
  545.         boolean headerAuthentication = headerType.isUsabledForAuthentication();
  546.         if(headerDuplicati || tokenAudit) {
  547.             prefix = "[Header '"+headerTokenRest+"'] ";
  548.         }
  549.         
  550.         /*
  551.          * == signature ==
  552.          */
  553.         
  554.         OpenSPCoop2Message msgToken = null;
  555.         try {
  556.             msgToken = msg.getFactory().createMessage(MessageType.JSON, MessageRole.NONE, 
  557.                 HttpConstants.CONTENT_TYPE_JSON, token.getBytes(), null, null).getMessage_throwParseException();
  558.         }catch(Exception e) {
  559.             throw new ProtocolException(e.getMessage(),e);
  560.         }
  561.         String payloadToken = null;
  562.         X509Certificate x509 = null;
  563.         String kid = null;
  564.         try {
  565.         
  566.             //  ** Timestamp **
  567.             Long timeToLive = this.modiProperties.getRestSecurityTokenClaimsIatTimeCheckMilliseconds();
  568.             if(securityConfig.getCheckTtlIatMilliseconds()!=null) {
  569.                 timeToLive = securityConfig.getCheckTtlIatMilliseconds();
  570.             }
  571.             if(timeToLive!=null && msg!=null) {
  572.                 msg.addContextProperty(ModICostanti.MODIPA_OPENSPCOOP2_MSG_CONTEXT_IAT_TTL_CHECK, timeToLive);
  573.             }
  574.             
  575.             MessageSecurityReceiver_jose joseSignature = new MessageSecurityReceiver_jose();
  576.             MessageSecurityContextParameters messageSecurityContextParameters = new MessageSecurityContextParameters();
  577.             MessageSecurityContext messageSecurityContext = new MessageSecurityContext_impl(messageSecurityContextParameters);
  578.             Map<String,Object> secProperties = new HashMap<>();
  579.             secProperties.put(SecurityConstants.SECURITY_ENGINE, SecurityConstants.SECURITY_ENGINE_JOSE);
  580.             secProperties.put(SecurityConstants.ACTION, SecurityConstants.SIGNATURE_ACTION);
  581.             secProperties.put(SecurityConstants.SIGNATURE_MODE, SecurityConstants.SIGNATURE_MODE_COMPACT);
  582.             secProperties.put(SecurityConstants.SIGNATURE_DETACHED, SecurityConstants.SIGNATURE_DETACHED_FALSE);
  583.             secProperties.put(SecurityConstants.DETACH_SECURITY_INFO, SecurityConstants.TRUE);
  584.             secProperties.put(SecurityConstants.JOSE_USE_HEADERS, SecurityConstants.JOSE_USE_HEADERS_TRUE);
  585.             secProperties.put(SecurityConstants.JOSE_USE_HEADERS_JWK, SecurityConstants.JOSE_USE_HEADERS_FALSE);
  586.             secProperties.put(SecurityConstants.JOSE_USE_HEADERS_JKU, SecurityConstants.JOSE_USE_HEADERS_FALSE);
  587.             secProperties.put(SecurityConstants.JOSE_USE_HEADERS_X5T, SecurityConstants.JOSE_USE_HEADERS_FALSE);
  588.             if(integritaKid || useKIDtokenHeader) {
  589.                 secProperties.put(SecurityConstants.JOSE_USE_HEADERS_KID, SecurityConstants.JOSE_USE_HEADERS_TRUE);
  590.                 secProperties.put(SecurityConstants.JOSE_USE_HEADERS_X5C, SecurityConstants.JOSE_USE_HEADERS_FALSE);
  591.                 secProperties.put(SecurityConstants.JOSE_USE_HEADERS_X5U, SecurityConstants.JOSE_USE_HEADERS_FALSE);
  592.                 secProperties.put(SecurityConstants.JOSE_USE_HEADERS_X5T_256, SecurityConstants.JOSE_USE_HEADERS_FALSE);
  593.             }
  594.             else {
  595.                 secProperties.put(SecurityConstants.JOSE_USE_HEADERS_KID, SecurityConstants.JOSE_USE_HEADERS_FALSE);
  596.                 
  597.                 boolean x5c = tokenAudit && apiSoap ? this.modiProperties.isSecurityTokenAuditApiSoapX509RiferimentoX5c() : securityConfig.isX5c();
  598.                 secProperties.put(SecurityConstants.JOSE_USE_HEADERS_X5C, x5c ? SecurityConstants.JOSE_USE_HEADERS_TRUE: SecurityConstants.JOSE_USE_HEADERS_FALSE);
  599.                 
  600.                 boolean x5u = tokenAudit && apiSoap ? this.modiProperties.isSecurityTokenAuditApiSoapX509RiferimentoX5u() : securityConfig.isX5u();
  601.                 secProperties.put(SecurityConstants.JOSE_USE_HEADERS_X5U, x5u ? SecurityConstants.JOSE_USE_HEADERS_TRUE: SecurityConstants.JOSE_USE_HEADERS_FALSE);
  602.                 
  603.                 boolean x5t = tokenAudit && apiSoap ? this.modiProperties.isSecurityTokenAuditApiSoapX509RiferimentoX5t() : securityConfig.isX5t();
  604.                 secProperties.put(SecurityConstants.JOSE_USE_HEADERS_X5T_256, x5t ? SecurityConstants.JOSE_USE_HEADERS_TRUE: SecurityConstants.JOSE_USE_HEADERS_FALSE);
  605.             }
  606.             secProperties.put(SecurityConstants.JOSE_USE_HEADERS_TRUSTSTORE_TYPE, trustStoreCertificati.getSecurityMessageTruststoreType());
  607.             if(!trustStoreCertificati.isSecurityMessageTruststoreRemote()) {
  608.                 secProperties.put(SecurityConstants.JOSE_USE_HEADERS_TRUSTSTORE_FILE, trustStoreCertificati.getSecurityMessageTruststorePath());
  609.             }
  610.             if(!trustStoreCertificati.isSecurityMessageTruststoreJWK() && !trustStoreCertificati.isSecurityMessageTruststoreRemote() &&
  611.                 trustStoreCertificati.getSecurityMessageTruststorePassword()!=null) {
  612.                 secProperties.put(SecurityConstants.JOSE_USE_HEADERS_TRUSTSTORE_PASSWORD, trustStoreCertificati.getSecurityMessageTruststorePassword());
  613.             }
  614.             if(trustStoreCertificati.getSecurityMessageTruststoreCRLs()!=null) {
  615.                 secProperties.put(SecurityConstants.SIGNATURE_CRL, trustStoreCertificati.getSecurityMessageTruststoreCRLs());
  616.             }
  617.             if(trustStoreCertificati.getSecurityMessageTruststoreOCSPPolicy()!=null) {
  618.                 secProperties.put(SecurityConstants.SIGNATURE_OCSP, trustStoreCertificati.getSecurityMessageTruststoreOCSPPolicy());
  619.             }
  620.             if(trustStoreCertificati.isSecurityMessageTruststoreRemote()) { 
  621.                 RemoteKeyType keyType = this.modiProperties.getRemoteKeyType(trustStoreCertificati.getSecurityMessageTruststoreType());
  622.                 secProperties.put(SecurityConstants.JOSE_USE_HEADERS_TRUSTSTORE_REMOTE_STORE_PROVIDER, new RemoteStoreProvider(this.requestInfo, keyType));
  623.                 secProperties.put(SecurityConstants.JOSE_USE_HEADERS_TRUSTSTORE_REMOTE_STORE_KEY_TYPE, keyType);
  624.                 secProperties.put(SecurityConstants.JOSE_USE_HEADERS_TRUSTSTORE_REMOTE_STORE_CONFIG, this.modiProperties.getRemoteStoreConfig(trustStoreCertificati.getSecurityMessageTruststoreType(), idSoggetto));
  625.             }
  626.             if(securityConfig.isX5u() &&
  627.                 trustStoreSsl!=null && trustStoreSsl.getSecurityMessageTruststorePath()!=null) {
  628.                 secProperties.put(SecurityConstants.JOSE_USE_HEADERS_TRUSTSTORE_SSL_FILE, trustStoreSsl.getSecurityMessageTruststorePath());
  629.                 secProperties.put(SecurityConstants.JOSE_USE_HEADERS_TRUSTSTORE_SSL_TYPE, trustStoreSsl.getSecurityMessageTruststoreType());
  630.                 if(trustStoreSsl.getSecurityMessageTruststorePassword()!=null) {
  631.                     secProperties.put(SecurityConstants.JOSE_USE_HEADERS_TRUSTSTORE_SSL_PASSWORD, trustStoreSsl.getSecurityMessageTruststorePassword());
  632.                 }
  633.                 if(trustStoreSsl.getSecurityMessageTruststoreCRLs()!=null) {
  634.                     secProperties.put(SecurityConstants.JOSE_USE_HEADERS_TRUSTSTORE_SSL_CRL, trustStoreSsl.getSecurityMessageTruststoreCRLs());
  635.                 }
  636.                 if(trustStoreSsl.getSecurityMessageTruststoreOCSPPolicy()!=null) {
  637.                     secProperties.put(SecurityConstants.JOSE_USE_HEADERS_TRUSTSTORE_SSL_OCSP, trustStoreSsl.getSecurityMessageTruststoreOCSPPolicy());
  638.                 }
  639.             }
  640.             messageSecurityContext.setIncomingProperties(secProperties, false);
  641.             DynamicMapBuilderUtils.injectDynamicMap(busta, this.requestInfo, this.context, this.log);
  642.             joseSignature.process(messageSecurityContext, msgToken, busta, this.context);
  643.             joseSignature.detachSecurity(messageSecurityContext, msgToken.castAsRest());
  644.             
  645.             ModIRESTSecurity restSecurity = (ModIRESTSecurity) msg.getContextProperty(ModICostanti.MODIPA_OPENSPCOOP2_MSG_CONTEXT_SBUSTAMENTO_REST);
  646.             if(restSecurity==null) {
  647.                 restSecurity = new ModIRESTSecurity(securityTokenHeader, request);
  648.                 msg.addContextProperty(ModICostanti.MODIPA_OPENSPCOOP2_MSG_CONTEXT_SBUSTAMENTO_REST, restSecurity);
  649.             }
  650.             else {
  651.                 restSecurity.getTokenHeaderNames().add(securityTokenHeader);
  652.             }

  654.             ByteArrayOutputStream bout = new ByteArrayOutputStream();
  655.             msgToken.writeTo(bout, true);
  656.             bout.flush();
  657.             bout.close();
  658.             
  659.             payloadToken = bout.toString();
  660.             /** System.out.println("PAYLOAD TOKEN ["+payloadToken+"]"); */  
  661.             
  662.             x509 = joseSignature.getX509Certificate();
  663.             /** System.out.println("CERTIFICATE ["+x509.getSubjectX500Principal().toString()+"]"); */
  664.             
  665.             kid = joseSignature.getCertificateId();
  666.             
  667.         }catch(Exception e) {
  668.             logError("Errore durante la validazione del token di sicurezza: "+e.getMessage(),e);
  669.             erroriValidazione.add(this.validazioneUtils.newEccezioneValidazione(CodiceErroreCooperazione.SICUREZZA_FIRMA_NON_VALIDA, 
  670.                     prefix+e.getMessage(),e));
  671.             return token;
  672.         }
  673.         
  674.         if(integritaKid || useKIDtokenHeader) {
  675.             if(kid==null) {
  676.                 erroriValidazione.add(this.validazioneUtils.newEccezioneValidazione(
  677.                         request ? CodiceErroreCooperazione.SERVIZIO_APPLICATIVO_FRUITORE_NON_PRESENTE :
  678.                             CodiceErroreCooperazione.SERVIZIO_APPLICATIVO_EROGATORE_NON_PRESENTE, 
  679.                         prefix+"Riferimento alla chiave (kid) non presente"));
  680.             }
  681.             else {
  682.                 
  683.                 if(!headerDuplicati || headerAuthentication) {
  684.                     busta.addProperty(tokenAudit ? ModICostanti.MODIPA_BUSTA_EXT_PROFILO_SICUREZZA_MESSAGGIO_CORNICE_SICUREZZA_AUDIT_KID : ModICostanti.MODIPA_BUSTA_EXT_PROFILO_SICUREZZA_MESSAGGIO_KID, 
  685.                             kid);
  686.                     
  687.                     if(headerDuplicati) {
  688.                         this.context.addObject(ModICostanti.MODIPA_CONTEXT_KID_AUTHORIZATION, x509);
  689.                     }
  690.                 }
  691.                 else {
  692.                     String kidAuthorization = null;
  693.                     Object oKidAuthorization = this.context.removeObject(ModICostanti.MODIPA_CONTEXT_KID_AUTHORIZATION);
  694.                     if(oKidAuthorization instanceof String) {
  695.                         kidAuthorization = (String) oKidAuthorization;
  696.                     }
  697.                     if(kidAuthorization!=null) { 
  698.                         if(!kidAuthorization.equals(kid)) {
  699.                             StringBuilder sb = new StringBuilder();
  700.                             sb.append(HttpConstants.AUTHORIZATION).append(" ");
  701.                             sb.append("kid=\"").append(kidAuthorization).append("\"");
  702.                             sb.append("\n");
  703.                             sb.append(headerTokenRest).append(" ");
  704.                             sb.append("kid=\"").append(kid).append("\"");
  705.                             erroriValidazione.add(this.validazioneUtils.newEccezioneValidazione(
  706.                                     request ? CodiceErroreCooperazione.SERVIZIO_APPLICATIVO_FRUITORE_NON_VALIDO :
  707.                                         CodiceErroreCooperazione.SERVIZIO_APPLICATIVO_EROGATORE_NON_VALIDO, 
  708.                                     "I token '"+HttpConstants.AUTHORIZATION+"' e '"+headerTokenRest+"' risultano firmati da certificati differenti\n"+sb.toString()));
  709.                         }
  710.                     }
  711.                     else {
  712.                         if(erroriValidazione.isEmpty()) {
  713.                             erroriValidazione.add(this.validazioneUtils.newEccezioneValidazione(CodiceErroreCooperazione.SICUREZZA_TOKEN_NON_PRESENTE, 
  714.                                     "Riferimento alla chiave (kid) nell'header '"+HttpConstants.AUTHORIZATION+"' non presente"));
  715.                         }
  716.                     }
  717.                 }
  718.                 
  719.                 if(request &&
  720.                         (!headerDuplicati || headerAuthentication) 
  721.                         ){
  722.                             
  723.                         if(msg==null || msg.getTransportRequestContext()==null || msg.getTransportRequestContext().getInterfaceName()==null) {
  724.                             throw new ProtocolException("ID Porta non presente");
  725.                         }
  726.                         IDPortaApplicativa idPA = new IDPortaApplicativa();
  727.                         idPA.setNome(msg.getTransportRequestContext().getInterfaceName());
  728.                         PortaApplicativa pa = null;
  729.                         try {
  730.                             pa = this.factory.getCachedConfigIntegrationReader(this.state, this.requestInfo).getPortaApplicativa(idPA);
  731.                         }catch(Exception e) {
  732.                             throw new ProtocolException(e.getMessage(),e);
  733.                         }
  734.                         boolean autenticazioneToken = pa!=null && pa.getGestioneToken()!=null && pa.getGestioneToken().getPolicy()!=null && StringUtils.isNotEmpty(pa.getGestioneToken().getPolicy());
  735.                         if(autenticazioneToken) {
  736.                             // l'autenticazione dell'applicativo mittente avviene per token
  737.                             // Il token rappresenta:
  738.                             // - un integrity nel caso PDND + Integrity
  739.                             // - una configurazione errata. In questo caso l'header Authorization non verrà validato con successo (es. certificato x509 non presente nel token).
  740.                             //   Se per caso risultasse corretto non è un problema
  741.                         }
  742.                         else {
  743.                             
  744.                             String clientId = readClientIdSafe(payloadToken);
  745.                             if(clientId!=null) {
  746.                                 /** PER ADESSO NON SUPPORTATO 
  747.                                 identificazioneApplicativoMittente(kid,msg,busta);
  748.                                  */
  749.                             }
  750.                             
  751.                         }
  752.                     }
  753.             }
  754.         }
  755.         else {
  756.             if(x509==null || x509.getSubjectX500Principal()==null) {
  757.                 erroriValidazione.add(this.validazioneUtils.newEccezioneValidazione(
  758.                         request ? CodiceErroreCooperazione.SERVIZIO_APPLICATIVO_FRUITORE_NON_PRESENTE :
  759.                             CodiceErroreCooperazione.SERVIZIO_APPLICATIVO_EROGATORE_NON_PRESENTE, 
  760.                         prefix+"Certificato X509 mittente non presente"));
  761.             }
  762.             else {
  763.                 
  764.                 if(!headerDuplicati || headerAuthentication) {
  765.                     busta.addProperty(tokenAudit ? ModICostanti.MODIPA_BUSTA_EXT_PROFILO_SICUREZZA_MESSAGGIO_CORNICE_SICUREZZA_AUDIT_X509_SUBJECT : ModICostanti.MODIPA_BUSTA_EXT_PROFILO_SICUREZZA_MESSAGGIO_X509_SUBJECT, 
  766.                             x509.getSubjectX500Principal().toString());
  767.                     if(x509.getIssuerX500Principal()!=null) {
  768.                         busta.addProperty(tokenAudit ? ModICostanti.MODIPA_BUSTA_EXT_PROFILO_SICUREZZA_MESSAGGIO_CORNICE_SICUREZZA_AUDIT_X509_ISSUER : ModICostanti.MODIPA_BUSTA_EXT_PROFILO_SICUREZZA_MESSAGGIO_X509_ISSUER, 
  769.                                 x509.getIssuerX500Principal().toString());
  770.                     }
  771.                     
  772.                     if(headerDuplicati) {
  773.                         this.context.addObject(ModICostanti.MODIPA_CONTEXT_X509_AUTHORIZATION, x509);
  774.                     }
  775.                 }
  776.                 else {
  777.                     /**
  778.                     String subjectAuthorization = busta.getProperty(busta.getProperty(ModICostanti.MODIPA_BUSTA_EXT_PROFILO_SICUREZZA_MESSAGGIO_X509_SUBJECT));
  779.                     String issuerAuthorization = busta.getProperty(busta.getProperty(ModICostanti.MODIPA_BUSTA_EXT_PROFILO_SICUREZZA_MESSAGGIO_X509_ISSUER));
  780.                     String subjectIntegrity = x509.getSubjectX500Principal().toString();
  781.                     String issuerIntegrity = x509.getIssuerX500Principal().toString();
  782.                     boolean subjectValid = false;
  783.                     if(subjectIntegrity!=null && subjectAuthorization!=null) {
  784.                         subjectValid = CertificateUtils.sslVerify(subjectAuthorization, subjectIntegrity, PrincipalType.subject, this.log);
  785.                     }
  786.                     boolean issuerValid = true;
  787.                     if(issuerAuthorization!=null && !"".equals(issuerAuthorization)) {
  788.                         if(issuerIntegrity==null) {
  789.                             issuerValid = false;
  790.                         }
  791.                         else {
  792.                             issuerValid = CertificateUtils.sslVerify(issuerAuthorization, issuerIntegrity, PrincipalType.issuer, this.log);
  793.                         }
  794.                     }
  795.                     else {
  796.                         issuerValid = (issuerIntegrity == null);
  797.                     }
  798.                     
  799.                     if(!subjectValid || !issuerValid){
  800.                         erroriValidazione.add(this.validazioneUtils.newEccezioneValidazione(
  801.                                 request ? CodiceErroreCooperazione.SERVIZIO_APPLICATIVO_FRUITORE_NON_VALIDO :
  802.                                     CodiceErroreCooperazione.SERVIZIO_APPLICATIVO_EROGATORE_NON_VALIDO, 
  803.                                 "I token '"+HttpConstants.AUTHORIZATION+"' e '"+headerTokenRest+"' risultano firmati da certificati differenti"));
  804.                     }*/
  805.                     X509Certificate x509Authorization = null;
  806.                     Object oX509Authorization = this.context.removeObject(ModICostanti.MODIPA_CONTEXT_X509_AUTHORIZATION);
  807.                     if(oX509Authorization instanceof X509Certificate) {
  808.                         x509Authorization = (X509Certificate) oX509Authorization;
  809.                     }
  810.                     if(x509Authorization!=null) { 
  811.                         if(!x509Authorization.equals(x509)) {
  812.                             StringBuilder sb = new StringBuilder();
  813.                             sb.append(HttpConstants.AUTHORIZATION).append(" ");
  814.                             sb.append("subject=\"").append(x509Authorization.getSubjectX500Principal().toString()).append("\"");
  815.                             if(x509Authorization.getIssuerX500Principal()!=null) {
  816.                                 sb.append(" issuer=\"").append(x509Authorization.getIssuerX500Principal().toString()).append("\"");
  817.                             }
  818.                             sb.append("\n");
  819.                             sb.append(headerTokenRest).append(" ");
  820.                             sb.append("subject=\"").append(x509.getSubjectX500Principal().toString()).append("\"");
  821.                             if(x509.getIssuerX500Principal()!=null) {
  822.                                 sb.append(" issuer=\"").append(x509.getIssuerX500Principal().toString()).append("\"");
  823.                             }
  824.                             erroriValidazione.add(this.validazioneUtils.newEccezioneValidazione(
  825.                                     request ? CodiceErroreCooperazione.SERVIZIO_APPLICATIVO_FRUITORE_NON_VALIDO :
  826.                                         CodiceErroreCooperazione.SERVIZIO_APPLICATIVO_EROGATORE_NON_VALIDO, 
  827.                                     "I token '"+HttpConstants.AUTHORIZATION+"' e '"+headerTokenRest+"' risultano firmati da certificati differenti\n"+sb.toString()));
  828.                         }
  829.                     }
  830.                     else {
  831.                         if(erroriValidazione.isEmpty()) {
  832.                             erroriValidazione.add(this.validazioneUtils.newEccezioneValidazione(CodiceErroreCooperazione.SICUREZZA_TOKEN_NON_PRESENTE, 
  833.                                     "Certificato x509 nell'header '"+HttpConstants.AUTHORIZATION+"' non presente"));
  834.                         }
  835.                     }
  836.                 }
  837.                 
  838.                 if(request &&
  839.                     (!headerDuplicati || headerAuthentication) 
  840.                     ){
  841.                         
  842.                     if(msg==null || msg.getTransportRequestContext()==null || msg.getTransportRequestContext().getInterfaceName()==null) {
  843.                         throw new ProtocolException("ID Porta non presente");
  844.                     }
  845.                     IDPortaApplicativa idPA = new IDPortaApplicativa();
  846.                     idPA.setNome(msg.getTransportRequestContext().getInterfaceName());
  847.                     PortaApplicativa pa = null;
  848.                     try {
  849.                         pa = this.factory.getCachedConfigIntegrationReader(this.state, this.requestInfo).getPortaApplicativa(idPA);
  850.                     }catch(Exception e) {
  851.                         throw new ProtocolException(e.getMessage(),e);
  852.                     }
  853.                     boolean autenticazioneToken = pa!=null && pa.getGestioneToken()!=null && pa.getGestioneToken().getPolicy()!=null && StringUtils.isNotEmpty(pa.getGestioneToken().getPolicy());
  854.                     if(autenticazioneToken) {
  855.                         // l'autenticazione dell'applicativo mittente avviene per token
  856.                         // Il token rappresenta:
  857.                         // - un integrity nel caso PDND + Integrity
  858.                         // - una configurazione errata. In questo caso l'header Authorization non verrà validato con successo (es. certificato x509 non presente nel token).
  859.                         //   Se per caso risultasse corretto non è un problema
  860.                     }
  861.                     else {
  862.                         identificazioneApplicativoMittente(x509,msg,busta,msgDiag);
  863.                     }
  864.                 }
  865.             }
  866.         }
  867.         
  868.         if(request && this.context!=null) {
  869.             
  870.             SecurityToken securityTokenForContext = ModIUtilities.newSecurityToken(this.context);
  871.             
  872.             RestMessageSecurityToken restSecurityToken = new RestMessageSecurityToken();
  873.             
  874.             if(x509!=null) {
  875.                 restSecurityToken.setCertificate(new CertificateInfo(x509, securityTokenHeader));
  876.             }
  877.             if(kid!=null) {
  878.                 restSecurityToken.setKid(kid);
  879.             }
  880.             restSecurityToken.setToken(token);
  881.             restSecurityToken.setHttpHeaderName(securityTokenHeader);
  882.             if(tokenAudit) {
  883.                 securityTokenForContext.setAudit(restSecurityToken);
  884.             }
  885.             else if(headerDuplicati) {
  886.                 if(headerAuthentication) {
  887.                     securityTokenForContext.setAuthorization(restSecurityToken);
  888.                 }
  889.                 else {
  890.                     securityTokenForContext.setIntegrity(restSecurityToken);    
  891.                 }
  892.             }
  893.             else {
  894.                 if(HttpConstants.AUTHORIZATION.equalsIgnoreCase(securityTokenHeader)) {
  895.                     securityTokenForContext.setAuthorization(restSecurityToken);
  896.                 }
  897.                 else {
  898.                     securityTokenForContext.setIntegrity(restSecurityToken);
  899.                 }
  900.             }
  901.             
  902.         }
  903.         
  904.         // NOTA: Inizializzare da qua il dynamicMap altrimenti non ci finisce l'identificazione del mittente effettuata dal metodo sopra 'identificazioneApplicativoMittente'
  905.         Map<String, Object> dynamicMap = null;
  906.         Map<String, Object> dynamicMapRequest = null;
  907.         if(!request) {
  908.             dynamicMapRequest = ModIUtilities.removeDynamicMapRequest(this.context);
  909.         }
  910.         try {
  911.             if(dynamicMapRequest!=null) {
  912.                 dynamicMap = DynamicUtils.buildDynamicMapResponse(msg, this.context, null, this.log, bufferMessageReadOnly, dynamicMapRequest);
  913.             }
  914.             else {
  915.                 dynamicMap = DynamicUtils.buildDynamicMap(msg, this.context, datiRichiesta, this.log, bufferMessageReadOnly);
  916.                 ModIUtilities.saveDynamicMapRequest(this.context, dynamicMap);
  917.             }
  918.         }catch(Exception e) {
  919.             throw new ProtocolException(e.getMessage(),e);
  920.         }
  921.         if(dynamicMapParameter!=null && dynamicMap!=null) {
  922.             dynamicMapParameter.putAll(dynamicMap);
  923.         }
  924.         
  925.         
  926.         try {
  927.             JsonNode jsonNode = JSONUtils.getInstance().getAsNode(payloadToken);
  928.             if(!(jsonNode instanceof ObjectNode)) {
  929.                 throw new ProtocolException("Payload del token possiede una struttura non valida");
  930.             }
  931.             ObjectNode objectNode = (ObjectNode) jsonNode;
  932.             
  933.             if(objectNode.has(Claims.JSON_WEB_TOKEN_RFC_7519_ISSUED_AT)) {
  934.                 Object iat = objectNode.get(Claims.JSON_WEB_TOKEN_RFC_7519_ISSUED_AT);
  935.                 if(iat==null) {
  936.                     erroriValidazione.add(this.validazioneUtils.newEccezioneValidazione(CodiceErroreCooperazione.ORA_REGISTRAZIONE_NON_PRESENTE, 
  937.                             prefix+getErroreTokenSenzaClaim(Claims.JSON_WEB_TOKEN_RFC_7519_ISSUED_AT)));
  938.                 }
  939.                 Date iatDate = toDate(iat, erroriValidazione, CodiceErroreCooperazione.ORA_REGISTRAZIONE_NON_VALIDA, prefix, Claims.JSON_WEB_TOKEN_RFC_7519_ISSUED_AT);
  940.                 if(iatDate!=null) { // altrimenti viene segnalato errore in erroriValidazione
  941.                     String iatValue = DateUtils.getSimpleDateFormatMs().format(iatDate);
  942.                     if(!headerDuplicati || headerAuthentication) {
  943.                         busta.addProperty(tokenAudit ? ModICostanti.MODIPA_BUSTA_EXT_PROFILO_SICUREZZA_MESSAGGIO_CORNICE_SICUREZZA_AUDIT_IAT : ModICostanti.MODIPA_BUSTA_EXT_PROFILO_SICUREZZA_MESSAGGIO_IAT, 
  944.                                 iatValue);
  945.                     }
  946.                     else {
  947.                         String iatAuthorization = busta.getProperty(ModICostanti.MODIPA_BUSTA_EXT_PROFILO_SICUREZZA_MESSAGGIO_IAT);
  948.                         if(!iatValue.equals(iatAuthorization)) {
  949.                             busta.addProperty(ModICostanti.MODIPA_BUSTA_EXT_PROFILO_SICUREZZA_MESSAGGIO_REST_INTEGRITY_IAT, iatValue);
  950.                         }
  951.                     }
  952.                 }
  953.             }
  954.             else {
  955.                 erroriValidazione.add(this.validazioneUtils.newEccezioneValidazione(CodiceErroreCooperazione.ORA_REGISTRAZIONE_NON_PRESENTE, 
  956.                         prefix+getErroreTokenSenzaClaim(Claims.JSON_WEB_TOKEN_RFC_7519_ISSUED_AT)));
  957.             }
  958.             
  959.             if(objectNode.has(Claims.JSON_WEB_TOKEN_RFC_7519_EXPIRED)) {
  960.                 Object exp = objectNode.get(Claims.JSON_WEB_TOKEN_RFC_7519_EXPIRED);
  961.                 if(exp==null) {
  962.                     erroriValidazione.add(this.validazioneUtils.newEccezioneValidazione(CodiceErroreCooperazione.SCADENZA_NON_PRESENTE, 
  963.                             prefix+getErroreTokenSenzaClaim(Claims.JSON_WEB_TOKEN_RFC_7519_EXPIRED)));
  964.                 }
  965.                 Date expDate = toDate(exp, erroriValidazione, CodiceErroreCooperazione.SCADENZA_NON_VALIDA, prefix, Claims.JSON_WEB_TOKEN_RFC_7519_EXPIRED);
  966.                 if(expDate!=null) { // altrimenti viene segnalato errore in erroriValidazione
  967.                     String expValue = DateUtils.getSimpleDateFormatMs().format(expDate);
  968.                     if(!headerDuplicati || headerAuthentication) {
  969.                         busta.addProperty(tokenAudit ? ModICostanti.MODIPA_BUSTA_EXT_PROFILO_SICUREZZA_MESSAGGIO_CORNICE_SICUREZZA_AUDIT_EXP : ModICostanti.MODIPA_BUSTA_EXT_PROFILO_SICUREZZA_MESSAGGIO_EXP, 
  970.                                 expValue);
  971.                     }
  972.                     else {
  973.                         String expAuthorization = busta.getProperty(ModICostanti.MODIPA_BUSTA_EXT_PROFILO_SICUREZZA_MESSAGGIO_EXP);
  974.                         if(!expValue.equals(expAuthorization)) {
  975.                             busta.addProperty(ModICostanti.MODIPA_BUSTA_EXT_PROFILO_SICUREZZA_MESSAGGIO_REST_INTEGRITY_EXP, expValue);
  976.                         }
  977.                     }
  978.                 }
  979.             }
  980.             else {
  981.                 erroriValidazione.add(this.validazioneUtils.newEccezioneValidazione(CodiceErroreCooperazione.SCADENZA_NON_PRESENTE, 
  982.                         prefix+getErroreTokenSenzaClaim(Claims.JSON_WEB_TOKEN_RFC_7519_EXPIRED)));
  983.             }
  984.             
  985.             if(objectNode.has(Claims.JSON_WEB_TOKEN_RFC_7519_NOT_TO_BE_USED_BEFORE)) {
  986.                 Object nbf = objectNode.get(Claims.JSON_WEB_TOKEN_RFC_7519_NOT_TO_BE_USED_BEFORE);
  987.                 if(nbf!=null) {
  988.                     Date nbfDate = toDate(nbf, erroriValidazione, CodiceErroreCooperazione.SCADENZA_NON_VALIDA, prefix, Claims.JSON_WEB_TOKEN_RFC_7519_NOT_TO_BE_USED_BEFORE);
  989.                     if(nbfDate!=null) { // altrimenti viene segnalato errore in erroriValidazione
  990.                         String nbfValue = DateUtils.getSimpleDateFormatMs().format(nbfDate);
  991.                         if(!headerDuplicati || headerAuthentication) {
  992.                             busta.addProperty(tokenAudit ? ModICostanti.MODIPA_BUSTA_EXT_PROFILO_SICUREZZA_MESSAGGIO_CORNICE_SICUREZZA_AUDIT_NBF : ModICostanti.MODIPA_BUSTA_EXT_PROFILO_SICUREZZA_MESSAGGIO_NBF, 
  993.                                     nbfValue);
  994.                         }
  995.                         else {
  996.                             String nbfAuthorization = busta.getProperty(ModICostanti.MODIPA_BUSTA_EXT_PROFILO_SICUREZZA_MESSAGGIO_NBF);
  997.                             if(!nbfValue.equals(nbfAuthorization)) {
  998.                                 busta.addProperty(ModICostanti.MODIPA_BUSTA_EXT_PROFILO_SICUREZZA_MESSAGGIO_REST_INTEGRITY_NBF, nbfValue);
  999.                             }
  1000.                         }
  1001.                     }
  1002.                 }
  1003.             }
  1004.             
  1005.             if(objectNode.has(Claims.JSON_WEB_TOKEN_RFC_7519_AUDIENCE)) {
  1006.                 Object aud = objectNode.get(Claims.JSON_WEB_TOKEN_RFC_7519_AUDIENCE);
  1007.                 if(aud==null) {
  1008.                     erroriValidazione.add(this.validazioneUtils.newEccezioneValidazione(
  1009.                             request ? CodiceErroreCooperazione.SERVIZIO_APPLICATIVO_EROGATORE_NON_PRESENTE :
  1010.                                 CodiceErroreCooperazione.SERVIZIO_APPLICATIVO_FRUITORE_NON_PRESENTE, 
  1011.                         prefix+getErroreTokenSenzaClaim(Claims.JSON_WEB_TOKEN_RFC_7519_AUDIENCE)));
  1012.                 }
  1013.                 else {
  1014.                     String audValue = toString(aud);
  1015.                     if(tokenAudit) {
  1016.                         String audAuthorization = busta.getProperty(ModICostanti.MODIPA_BUSTA_EXT_PROFILO_SICUREZZA_MESSAGGIO_REST_AUDIENCE);
  1017.                         if(audAuthorization==null || !audValue.equals(audAuthorization)) {
  1018.                             busta.addProperty(ModICostanti.MODIPA_BUSTA_EXT_PROFILO_SICUREZZA_MESSAGGIO_CORNICE_SICUREZZA_AUDIT_AUDIENCE, audValue);
  1019.                         }
  1020.                     }
  1021.                     else {
  1022.                         if(!headerDuplicati || headerAuthentication) {
  1023.                             busta.addProperty(ModICostanti.MODIPA_BUSTA_EXT_PROFILO_SICUREZZA_MESSAGGIO_REST_AUDIENCE, audValue);
  1024.                         }
  1025.                         else {
  1026.                             String audAuthorization = busta.getProperty(ModICostanti.MODIPA_BUSTA_EXT_PROFILO_SICUREZZA_MESSAGGIO_REST_AUDIENCE);
  1027.                             if(!audValue.equals(audAuthorization)) {
  1028.                                 busta.addProperty(ModICostanti.MODIPA_BUSTA_EXT_PROFILO_SICUREZZA_MESSAGGIO_REST_INTEGRITY_AUDIENCE, audValue);
  1029.                             }
  1030.                         }
  1031.                     }
  1032.                 }
  1033.             }
  1034.             else {
  1035.                 if(request || buildSecurityTokenInRequest) {
  1036.                     erroriValidazione.add(this.validazioneUtils.newEccezioneValidazione(
  1037.                             request ? CodiceErroreCooperazione.SERVIZIO_APPLICATIVO_EROGATORE_NON_PRESENTE :
  1038.                                 CodiceErroreCooperazione.SERVIZIO_APPLICATIVO_FRUITORE_NON_PRESENTE, 
  1039.                         prefix+getErroreTokenSenzaClaim(Claims.JSON_WEB_TOKEN_RFC_7519_AUDIENCE)));
  1040.                 }
  1041.             }
  1042.             
  1043.             boolean jtiRequired = false;
  1044.             if(ModICostanti.MODIPA_PROFILO_SICUREZZA_MESSAGGIO_VALUE_IDAM02.equals(securityMessageProfile) ||
  1045.                     ModICostanti.MODIPA_PROFILO_SICUREZZA_MESSAGGIO_VALUE_IDAM0302.equals(securityMessageProfile) ||
  1046.                     ModICostanti.MODIPA_PROFILO_SICUREZZA_MESSAGGIO_VALUE_IDAM0402.equals(securityMessageProfile)) {
  1047.                 jtiRequired = true;
  1048.             }
  1049.             if(objectNode.has(Claims.JSON_WEB_TOKEN_RFC_7519_JWT_ID)) {
  1050.                 Object jti = objectNode.get(Claims.JSON_WEB_TOKEN_RFC_7519_JWT_ID);
  1051.                 if(jti==null) {
  1052.                     if(jtiRequired) {
  1053.                         erroriValidazione.add(this.validazioneUtils.newEccezioneValidazione(CodiceErroreCooperazione.IDENTIFICATIVO_MESSAGGIO_NON_PRESENTE, 
  1054.                                 prefix+getErroreTokenSenzaClaim(Claims.JSON_WEB_TOKEN_RFC_7519_JWT_ID)));
  1055.                     }
  1056.                 }
  1057.                 else {
  1058.                     String id = toString(jti);
  1059.                     if(tokenAudit) {
  1060.                         busta.addProperty(ModICostanti.MODIPA_BUSTA_EXT_PROFILO_SICUREZZA_MESSAGGIO_CORNICE_SICUREZZA_AUDIT_ID, id);
  1061.                     }
  1062.                     else {
  1063.                         boolean addAsIdBusta = true;
  1064.                         if(headerDuplicati) {
  1065.                             if(headerAuthentication) {
  1066.                                 if(!securityConfig.isMultipleHeaderUseJtiAuthorizationAsIdMessaggio()) {
  1067.                                     String idActual = busta.getProperty(ModICostanti.MODIPA_BUSTA_EXT_PROFILO_SICUREZZA_MESSAGGIO_ID);
  1068.                                     if(idActual==null || !idActual.equals(id)) {
  1069.                                         busta.addProperty(ModICostanti.MODIPA_BUSTA_EXT_PROFILO_SICUREZZA_MESSAGGIO_REST_AUTHORIZATION_ID, id);
  1070.                                     }
  1071.                                     addAsIdBusta = false;
  1072.                                 }
  1073.                             }
  1074.                             else {
  1075.                                 if(securityConfig.isMultipleHeaderUseJtiAuthorizationAsIdMessaggio()) {
  1076.                                     String idActual = busta.getProperty(ModICostanti.MODIPA_BUSTA_EXT_PROFILO_SICUREZZA_MESSAGGIO_ID);
  1077.                                     if(idActual==null || !idActual.equals(id)) {
  1078.                                         busta.addProperty(ModICostanti.MODIPA_BUSTA_EXT_PROFILO_SICUREZZA_MESSAGGIO_REST_INTEGRITY_ID, id);
  1079.                                     }
  1080.                                     addAsIdBusta = false;
  1081.                                 }
  1082.                                 else {
  1083.                                     // verifico se ho gia' impostato authorization
  1084.                                     String idActualAuthorization = busta.getProperty(ModICostanti.MODIPA_BUSTA_EXT_PROFILO_SICUREZZA_MESSAGGIO_REST_AUTHORIZATION_ID);
  1085.                                     if(idActualAuthorization!=null && idActualAuthorization.equals(id)) {
  1086.                                         busta.removeProperty(ModICostanti.MODIPA_BUSTA_EXT_PROFILO_SICUREZZA_MESSAGGIO_REST_AUTHORIZATION_ID);
  1087.                                     }
  1088.                                 }
  1089.                             }
  1090.                         }
  1091.                         if(addAsIdBusta) {
  1092.                             busta.addProperty(ModICostanti.MODIPA_BUSTA_EXT_PROFILO_SICUREZZA_MESSAGGIO_ID, id);
  1093.                             if(id.length()<=255) {
  1094.                                 busta.setID(id);
  1095.                             }
  1096.                         }
  1097.                     }
  1098.                 }
  1099.             }
  1100.             else {
  1101.                 if(jtiRequired) {
  1102.                     erroriValidazione.add(this.validazioneUtils.newEccezioneValidazione(CodiceErroreCooperazione.IDENTIFICATIVO_MESSAGGIO_NON_PRESENTE, 
  1103.                             prefix+getErroreTokenSenzaClaim(Claims.JSON_WEB_TOKEN_RFC_7519_JWT_ID)));
  1104.                 }
  1105.             }

  1107.             if(!request) {
  1108.                 corniceSicurezza = false; // permessa solo per i messaggi di richiesta
  1109.             }
  1110.             
  1111.             boolean readIss = true;
  1112.             boolean readSub = true;
  1113.             
  1114.             if(corniceSicurezza) {
  1115.                 
  1116.                 if(CostantiDB.MODIPA_PROFILO_SICUREZZA_MESSAGGIO_CORNICE_SICUREZZA_PATTERN_OLD.equals(patternCorniceSicurezza)) {
  1117.                     readIss = readCorniceSicurezzaCodiceEnteLegacy(objectNode, busta,
  1118.                             erroriValidazione, prefix);
  1119.                     readSub = readCorniceSicurezzaUserLegacy(objectNode, busta,
  1120.                             erroriValidazione, prefix);
  1121.                     readCorniceSicurezzaIpUserLegacy(objectNode, busta,
  1122.                             erroriValidazione, prefix);
  1123.                 }
  1124.                 else {
  1125.                     readCorniceSicurezzaSchema(objectNode, msg, busta,
  1126.                             erroriValidazione, prefix,
  1127.                             schemaCorniceSicurezza, securityConfig.getCorniceSicurezzaSchemaConfig());
  1128.                 }
  1129.                 
  1130.             }
  1131.             
  1132.             if(readIss &&
  1133.                 objectNode.has(Claims.JSON_WEB_TOKEN_RFC_7519_ISSUER)) {
  1134.                 Object iss = objectNode.get(Claims.JSON_WEB_TOKEN_RFC_7519_ISSUER);
  1135.                 if(iss!=null) {
  1136.                     busta.addProperty(tokenAudit ? ModICostanti.MODIPA_BUSTA_EXT_PROFILO_SICUREZZA_MESSAGGIO_CORNICE_SICUREZZA_AUDIT_ISSUER : ModICostanti.MODIPA_BUSTA_EXT_PROFILO_SICUREZZA_MESSAGGIO_REST_ISSUER, 
  1137.                             toString(iss));
  1138.                 }
  1139.             }
  1140.             if(readSub &&
  1141.                 objectNode.has(Claims.JSON_WEB_TOKEN_RFC_7519_SUBJECT)) {
  1142.                 Object sub = objectNode.get(Claims.JSON_WEB_TOKEN_RFC_7519_SUBJECT);
  1143.                 if(sub!=null) {
  1144.                     busta.addProperty(tokenAudit ? ModICostanti.MODIPA_BUSTA_EXT_PROFILO_SICUREZZA_MESSAGGIO_CORNICE_SICUREZZA_AUDIT_SUBJECT : ModICostanti.MODIPA_BUSTA_EXT_PROFILO_SICUREZZA_MESSAGGIO_REST_SUBJECT, 
  1145.                             toString(sub));
  1146.                 }
  1147.             }
  1148.             
  1149.             Object clientId = readObjectClientId(objectNode);
  1150.             if(clientId!=null) {
  1151.                 String clientIdValue = toString(clientId);
  1152.                 busta.addProperty(tokenAudit ? ModICostanti.MODIPA_BUSTA_EXT_PROFILO_SICUREZZA_MESSAGGIO_CORNICE_SICUREZZA_AUDIT_CLIENT_ID : ModICostanti.MODIPA_BUSTA_EXT_PROFILO_SICUREZZA_MESSAGGIO_REST_CLIENT_ID,clientIdValue);
  1153.             }
  1154.             
  1155.             
  1156.             if( (tokenAudit || integritaX509 || integritaKid) 
  1157.                     &&
  1158.                 objectNode.has(Costanti.PDND_PURPOSE_ID)
  1159.                 ) {
  1160.                 Object purposeId = objectNode.get(Costanti.PDND_PURPOSE_ID);
  1161.                 if(purposeId!=null) {
  1162.                     busta.addProperty(tokenAudit ? ModICostanti.MODIPA_BUSTA_EXT_PROFILO_SICUREZZA_MESSAGGIO_CORNICE_SICUREZZA_AUDIT_PURPOSE_ID : ModICostanti.MODIPA_BUSTA_EXT_PROFILO_SICUREZZA_MESSAGGIO_REST_INTEGRITY_PURPOSE_ID, 
  1163.                             toString(purposeId));
  1164.                 }
  1165.             }
  1166.             
  1167.             String digestHeader = HttpConstants.DIGEST;
  1168.             String digestValueInHeaderHTTP = null;
  1169.             if(integrita && !integritaCustom) {
  1170.                 
  1171.                 List<String> digests = null;
  1172.                 if(msg!=null) {
  1173.                     if(request && msg.getTransportRequestContext()!=null) {
  1174.                         digests = msg.getTransportRequestContext().getHeaderValues(digestHeader);
  1175.                     }
  1176.                     else if(!request && msg.getTransportResponseContext()!=null) {
  1177.                         digests = msg.getTransportResponseContext().getHeaderValues(digestHeader);
  1178.                     }
  1179.                 }   
  1180.                 String digest = null;
  1181.                 if(digests!=null && !digests.isEmpty()) {
  1182.                     digest = digests.get(0);
  1183.                 }
  1184.                 if(digest==null) {
  1185.                     if(msg.castAsRest().hasContent()) {
  1186.                         erroriValidazione.add(this.validazioneUtils.newEccezioneValidazione(CodiceErroreCooperazione.PROFILO_TRASMISSIONE_NON_PRESENTE, 
  1187.                                 getErrorHeaderHttpNonPresente(digestHeader)));
  1188.                     }
  1189.                 }
  1190.                 else if(digests.size()>1) {
  1191.                     erroriValidazione.add(this.validazioneUtils.newEccezioneValidazione(CodiceErroreCooperazione.PROFILO_TRASMISSIONE_PRESENTE_PIU_VOLTE, 
  1192.                             getErrorHeaderHttpPresentePiuVolte(digestHeader)));
  1193.                 }
  1194.                 else {
  1195.                     digestValueInHeaderHTTP = toString(digest);
  1196.                     busta.addProperty(ModICostanti.MODIPA_BUSTA_EXT_PROFILO_SICUREZZA_MESSAGGIO_DIGEST, digestValueInHeaderHTTP);
  1197.                     if(request && includiRequestDigest && this.context!=null) {
  1198.                         this.context.addObject(ModICostanti.MODIPA_CONTEXT_REQUEST_DIGEST, digestValueInHeaderHTTP);
  1199.                     }
  1200.                     
  1201.                     if(!msg.castAsRest().hasContent()) {
  1202.                         String role = MessageRole.REQUEST.equals(msg.getMessageRole()) ? "richiesta" : "risposta";
  1203.                         erroriValidazione.add(this.validazioneUtils.newEccezioneValidazione(CodiceErroreCooperazione.SICUREZZA_FIRMA_INTESTAZIONE_NON_VALIDA, 
  1204.                                 getErrorHeaderHttpPrefix(digestHeader)+" presente in una "+role+" con http payload vuoto"));
  1205.                     }
  1206.                 }
  1207.             }
  1208.             
  1209.             if(digestValueInHeaderHTTP!=null) {
  1210.                 
  1211.                 // Produco Digest Headers
  1212.                 ByteArrayOutputStream bout = new ByteArrayOutputStream();
  1213.                 msg.castAsRest().writeTo(bout, false, bufferMessageReadOnly, idTransazione);
  1214.                 bout.flush();
  1215.                 bout.close();
  1216.                 
  1217.                 List<DigestEncoding> digestEncoding = securityConfig.getDigestEncodingAccepted();
  1218.                 Map<DigestEncoding, String> newDigestValue = null;
  1219.                 boolean formatoSupportato = true;
  1220.                 if(digestValueInHeaderHTTP.startsWith(HttpConstants.DIGEST_ALGO_SHA_256+"=")) {
  1221.                     newDigestValue = HttpUtilities.getDigestHeaderValues(bout.toByteArray(), HttpConstants.DIGEST_ALGO_SHA_256,
  1222.                             digestEncoding.toArray(new DigestEncoding[1]));
  1223.                 }
  1224.                 else if(digestValueInHeaderHTTP.startsWith(HttpConstants.DIGEST_ALGO_SHA_384+"=")) {
  1225.                     newDigestValue = HttpUtilities.getDigestHeaderValues(bout.toByteArray(), HttpConstants.DIGEST_ALGO_SHA_384,
  1226.                             digestEncoding.toArray(new DigestEncoding[1]));
  1227.                 }
  1228.                 else if(digestValueInHeaderHTTP.startsWith(HttpConstants.DIGEST_ALGO_SHA_512+"=")) {
  1229.                     newDigestValue = HttpUtilities.getDigestHeaderValues(bout.toByteArray(), HttpConstants.DIGEST_ALGO_SHA_512,
  1230.                             digestEncoding.toArray(new DigestEncoding[1]));
  1231.                 }
  1232.                 else {
  1233.                     formatoSupportato = false;
  1234.                     erroriValidazione.add(this.validazioneUtils.newEccezioneValidazione(CodiceErroreCooperazione.SICUREZZA_FIRMA_INTESTAZIONE_NON_VALIDA, 
  1235.                             getErrorHeaderHttpPrefix(digestHeader)+" con un formato non supportato"));
  1236.                 }
  1237.                 
  1238.                 if(formatoSupportato) {
  1239.                     if(newDigestValue==null || newDigestValue.isEmpty()) {
  1240.                         erroriValidazione.add(this.validazioneUtils.newEccezioneValidazione(CodiceErroreCooperazione.SICUREZZA_FIRMA_INTESTAZIONE_NON_VALIDA, 
  1241.                                 "Calcolo Digest fallito"));
  1242.                     }
  1243.                     else {
  1244.                         boolean valido = false;
  1245.                         for (DigestEncoding de : digestEncoding) {
  1246.                             String check = newDigestValue.get(de);
  1247.                             if(check==null) { // non deve succedere
  1248.                                 erroriValidazione.add(this.validazioneUtils.newEccezioneValidazione(CodiceErroreCooperazione.SICUREZZA_FIRMA_INTESTAZIONE_NON_VALIDA, 
  1249.                                         "Encoding Digest '"+de+"' fallito"));
  1250.                             }
  1251.                             else if(check.equals(digestValueInHeaderHTTP)){
  1252.                                 valido=true;
  1253.                                 break;
  1254.                             }
  1255.                         }
  1256.                         if(!valido) {
  1257.                             erroriValidazione.add(this.validazioneUtils.newEccezioneValidazione(CodiceErroreCooperazione.SICUREZZA_FIRMA_NON_VALIDA, 
  1258.                                     getErrorHeaderHttpPrefix(digestHeader)+" possiede un valore non corrispondente al messaggio"));
  1259.                         }
  1260. /**                     else {
  1261. //                          System.out.println("VERIFICATO DIGEST HTTP");
  1262. //                      }*/
  1263.                     }
  1264.                 }
  1265.                 
  1266.             }
  1267.             
  1268.             String claimSignedHeader = this.modiProperties.getRestSecurityTokenClaimSignedHeaders();
  1269.             if(integrita && !integritaCustom && objectNode.has(claimSignedHeader)) {
  1270.                 
  1271.                 boolean findDigestInClaimSignedHeader = false;
  1272.                 
  1273.                 Map<String, List<String>> headerHttpAttesi = new HashMap<>();
  1274.                 
  1275.                 Object signedHeaders = objectNode.get(claimSignedHeader);
  1276.                 if(signedHeaders==null) {
  1277.                     if(integrita && msg.castAsRest().hasContent()) {
  1278.                         erroriValidazione.add(this.validazioneUtils.newEccezioneValidazione(CodiceErroreCooperazione.SICUREZZA_FIRMA_INTESTAZIONE_NON_PRESENTE, 
  1279.                                 prefix+getErroreTokenSenzaClaim(claimSignedHeader)));
  1280.                     }
  1281.                 }
  1282.                 else {
  1283.                     readSignedHeaders(signedHeaders, erroriValidazione, prefix, headerDuplicati,
  1284.                             busta, headerHttpAttesi,
  1285.                             claimSignedHeader);
  1286.                 }
  1287.                 
  1288.                 if(headerHttpAttesi!=null && !headerHttpAttesi.isEmpty()) {
  1289.                     Iterator<String> headers = headerHttpAttesi.keySet().iterator();
  1290.                     while (headers.hasNext()) {
  1291.                         String hdrName = headers.next();
  1292.                         List<String> hrdAttesiValues = headerHttpAttesi.get(hdrName);
  1293.                         boolean checkHdrAttesiSize = true;
  1294.                         List<String> hdrFound = null;
  1295.                         for (String hdrAttesoValue : hrdAttesiValues) {
  1296.                             boolean valid = false;
  1297.                             String valueInHttpHeader = null;
  1298.                             boolean multiHeader = false;
  1299.                             if(digestHeader.toLowerCase().equalsIgnoreCase(hdrName)) {
  1300.                                 checkHdrAttesiSize = false; // il controllo che non esista piu' di un header digest e' stato fatto in precedenza
  1301.                                 findDigestInClaimSignedHeader = true;
  1302.                                 if(digestValueInHeaderHTTP==null) {
  1303.                                     erroriValidazione.add(this.validazioneUtils.newEccezioneValidazione(CodiceErroreCooperazione.SICUREZZA_FIRMA_NON_VALIDA, 
  1304.                                             getErrorHeaderHttpPrefix(hdrName)+", dichiarato tra gli header firmati, non trovato"));
  1305.                                     valid = true; // per non far segnalare l'eccezione, che e' stata personalizzata sopra
  1306.                                 }
  1307.                                 else {
  1308.                                     valueInHttpHeader = digestValueInHeaderHTTP;
  1309.                                     valid = hdrAttesoValue.equals(digestValueInHeaderHTTP); 
  1310.                                     /**System.out.println("VALID DIGEST: "+valid);*/
  1311.                                 }
  1312.                             }
  1313.                             else {
  1314.                                 if(request && msg.getTransportRequestContext()!=null) {
  1315.                                     hdrFound = msg.getTransportRequestContext().getHeaderValues(hdrName);
  1316.                                 }
  1317.                                 else if(!request && msg.getTransportResponseContext()!=null) {
  1318.                                     hdrFound = msg.getTransportResponseContext().getHeaderValues(hdrName);
  1319.                                 }
  1320.                                 
  1321.                                 if(checkHdrAttesiSize && hdrFound!=null) {
  1322.                                     // Fix: per verificare che non esistano altri copie dell'header, oltre a quelli attesi, con valori differenti
  1323.                                     if(hrdAttesiValues.size()!=hdrFound.size()) {
  1324.                                         logError(getErrorHeaderHttpPrefix(hdrName)+" possiede "+(hdrFound!=null ? hdrFound.size() : 0)+" valori '"+(hdrFound!=null ? hdrFound.toString() : "non presente")+
  1325.                                                 "' mentre negli header firmati sono presenti "+hrdAttesiValues.size()+" valori '"+hrdAttesiValues.toString()+"'");
  1326.                                         erroriValidazione.add(this.validazioneUtils.newEccezioneValidazione(CodiceErroreCooperazione.SICUREZZA_FIRMA_NON_VALIDA, 
  1327.                                                 getErrorHeaderHttpPrefix(hdrName)+" possiede un numero di valori ("+(hdrFound!=null ? hdrFound.size() : 0)
  1328.                                                     +") differente rispetto al numero di valori ("+hrdAttesiValues.size()+") definiti negli header firmati"));
  1329.                                         valid = true; // per non far segnalare l'eccezione, che e' stata personalizzata sopra
  1330.                                         if(valid) {
  1331.                                             break; // e' inutile continuare a controllare i valori degli header
  1332.                                         }
  1333.                                     }
  1334.                                     checkHdrAttesiSize=false; // questo controllo per ogni header basta 1 volta, non serve farlo per ogni valore
  1335.                                 }
  1336.                                 
  1337.                                 if(hdrFound==null || hdrFound.isEmpty()) {
  1338.                                     erroriValidazione.add(this.validazioneUtils.newEccezioneValidazione(CodiceErroreCooperazione.SICUREZZA_FIRMA_NON_VALIDA, 
  1339.                                             getErrorHeaderHttpPrefix(hdrName)+", dichiarato tra gli header firmati, non trovato"));
  1340.                                     valid = true; // per non far segnalare l'eccezione, che e' stata personalizzata sopra
  1341.                                     if(valid) {
  1342.                                         break; // e' inutile continuare a controllare i valori degli header
  1343.                                     }
  1344.                                 }
  1345.                                 else if(hdrFound.size()==1) {
  1346.                                     valueInHttpHeader = hdrFound.get(0);
  1347.                                     valid = hdrAttesoValue.equals(valueInHttpHeader);
  1348.                                 }
  1349.                                 else {
  1350.                                     multiHeader = true;
  1351.                                     valueInHttpHeader = hdrFound.toString();
  1352.                                     valid = hdrFound.contains(hdrAttesoValue); 
  1353.                                 }
  1354.                                                                 
  1355.                                 /**System.out.println("VALID HDR '"+hdrName+"': "+valid);*/
  1356.                             }
  1357.                             if(!valid) {
  1358.                                 String errorMsg = "possiede un valore '"+valueInHttpHeader+"' differente";
  1359.                                 String errorExc = "possiede un valore differente";
  1360.                                 if(multiHeader) {
  1361.                                     errorMsg = "possiede dei valori '"+valueInHttpHeader+"' differenti";
  1362.                                     errorExc = "possiede dei valori differenti";
  1363.                                 }
  1364.                                 logError(getErrorHeaderHttpPrefix(hdrName)+" "+errorMsg+" rispetto a quello presente negli header firmati '"+hdrAttesoValue+"'");
  1365.                                 erroriValidazione.add(this.validazioneUtils.newEccezioneValidazione(CodiceErroreCooperazione.SICUREZZA_FIRMA_NON_VALIDA, 
  1366.                                         getErrorHeaderHttpPrefix(hdrName)+" "+errorExc+" rispetto a quello presente negli header firmati"));
  1367.                             }
  1368.                         }
  1369.                     }
  1370.                 }
  1371.                 
  1372.                 if(integrita && msg.castAsRest().hasContent() &&
  1373.                     !findDigestInClaimSignedHeader) {
  1374.                     erroriValidazione.add(this.validazioneUtils.newEccezioneValidazione(CodiceErroreCooperazione.SICUREZZA_FIRMA_INTESTAZIONE_NON_PRESENTE, 
  1375.                             getErrorHeaderHttpPrefix(digestHeader)+" non presente nella lista degli header firmati (token claim '"+claimSignedHeader+"')"));
  1376.                 }
  1377.             }
  1378.             else {
  1379.                 if(integrita && !integritaCustom && msg.castAsRest().hasContent()) {
  1380.                     erroriValidazione.add(this.validazioneUtils.newEccezioneValidazione(CodiceErroreCooperazione.SICUREZZA_FIRMA_INTESTAZIONE_NON_PRESENTE, 
  1381.                             prefix+getErroreTokenSenzaClaim(claimSignedHeader)));
  1382.                 }
  1383.             }
  1384.             
  1385.             
  1386.         }catch(Exception e) {
  1387.             logError("Errore durante il processamento del payload del token di sicurezza: "+e.getMessage(),e);
  1388.             erroriValidazione.add(this.validazioneUtils.newEccezioneValidazione(CodiceErroreCooperazione.SICUREZZA_TOKEN_NON_VALIDO, 
  1389.                     prefix+e.getMessage()));
  1390.         }
  1391.         
  1392.         return token;
  1393.     }
  1394.     
  1395.     private void readSignedHeaders(Object signedHeaders, List<Eccezione> erroriValidazione, String prefix, boolean headerDuplicati,
  1396.             Busta busta, Map<String, List<String>> headerHttpAttesi,
  1397.             String claimSignedHeader) throws ProtocolException {
  1398.         try {
  1399.             if(signedHeaders instanceof ArrayNode) {
  1400.                 ArrayNode arrayNode = (ArrayNode) signedHeaders;
  1401.                 if(arrayNode.size()<=0) {
  1402.                     throw new ProtocolException("atteso un array con almeno un valore");
  1403.                 }
  1404.                 for (int i = 0; i < arrayNode.size(); i++) {
  1405.                     JsonNode hdrNode = arrayNode.get(i);
  1406.                     String prefixArray = "array["+i+"]";
  1407.                     if(hdrNode==null) {
  1408.                         throw new ProtocolException(prefixArray+" non possiede un valore");
  1409.                     }
  1410.                     if(!(hdrNode instanceof ObjectNode)) {
  1411.                         throw new ProtocolException(prefixArray+" possiede una struttura errata");
  1412.                     }
  1413.                     ObjectNode oNode = (ObjectNode) hdrNode;
  1414.                     if(oNode.size()<=0) {
  1415.                         throw new ProtocolException(prefixArray+" possiede una struttura senza elementi");
  1416.                     }
  1417.                     Iterator<String> fieldNames = oNode.fieldNames();
  1418.                     while (fieldNames.hasNext()) {
  1419.                         String hdrName = fieldNames.next();
  1420.                         addSignedHeader(oNode, hdrName, headerDuplicati,
  1421.                                 busta, headerHttpAttesi, prefixArray);
  1422.                     }
  1423.                 }
  1424.             }
  1425.             else {
  1426.                 throw new ProtocolException("atteso un array");
  1427.             }
  1428.         }catch(Exception e) {
  1429.             logError("Errore durante il processamento del claim che definisce gli header HTTP firmati '"+claimSignedHeader+"': "+e.getMessage(),e);
  1430.             erroriValidazione.add(this.validazioneUtils.newEccezioneValidazione(CodiceErroreCooperazione.SICUREZZA_FIRMA_INTESTAZIONE_NON_VALIDA, 
  1431.                     prefix+"Claim '"+claimSignedHeader+"' con un formato non valido; "+ e.getMessage()));
  1432.         }
  1433.     }
  1434.     private void addSignedHeader(ObjectNode oNode, String hdrName, boolean headerDuplicati,
  1435.             Busta busta, Map<String, List<String>> headerHttpAttesi, String prefixArray) throws ProtocolException {
  1436.         try {
  1437.             String hdrValue = toString(oNode.get(hdrName));
  1438.             if(HttpConstants.AUTHORIZATION.equalsIgnoreCase(hdrName) && headerDuplicati) {
  1439.                 ModIUtilities.addHeaderProperty(busta, hdrName, HttpConstants.AUTHORIZATION_PREFIX_BEARER +"...TOKEN...");  
  1440.             }
  1441.             else {
  1442.                 ModIUtilities.addHeaderProperty(busta, hdrName, hdrValue);
  1443.             }
  1444.             TransportUtils.addHeader(headerHttpAttesi, hdrName, hdrValue);
  1445.         }catch(Exception e) {
  1446.             throw new ProtocolException(prefixArray+" possiede header '"+hdrName+"' con un valore non valido: "+e.getMessage(),e);
  1447.         }
  1448.     }
  1449.     
  1450.     private String readClientIdSafe(String payloadToken) {
  1451.         try {
  1452.             JsonNode jsonNode = JSONUtils.getInstance().getAsNode(payloadToken);
  1453.             if(!(jsonNode instanceof ObjectNode)) {
  1454.                 throw new ProtocolException("Payload del token possiede una struttura non valida");
  1455.             }
  1456.             ObjectNode objectNode = (ObjectNode) jsonNode;
  1457.             
  1458.             Object clientIdO = readObjectClientId(objectNode);
  1459.             if(clientIdO!=null) {
  1460.                 return toString(clientIdO);
  1461.             }
  1462.             return null;
  1463.             
  1464.         }catch(Exception e) {
  1465.             // ignore
  1466.             return null;
  1467.         }   
  1468.     }
  1469.     private Object readObjectClientId(ObjectNode objectNode) throws ProtocolException {
  1470.         Object clientId = null;
  1471.         String claimName = this.modiProperties.getRestSecurityTokenClaimsClientIdHeader();
  1472.         if(objectNode.has(Claims.INTROSPECTION_RESPONSE_RFC_7662_CLIENT_ID)) {
  1473.             clientId = objectNode.get(Claims.INTROSPECTION_RESPONSE_RFC_7662_CLIENT_ID);
  1474.         }
  1475.         else if(objectNode.has(Claims.OIDC_ID_TOKEN_AZP)) {
  1476.             clientId = objectNode.get(Claims.OIDC_ID_TOKEN_AZP);
  1477.         }
  1478.         else if(objectNode.has(claimName)) {
  1479.             clientId = objectNode.get(claimName);
  1480.         }
  1481.         return clientId;
  1482.     }   
  1483.     
  1484.     private void readCorniceSicurezzaSchema(ObjectNode objectNode, OpenSPCoop2Message msg, Busta busta,
  1485.             List<Eccezione> erroriValidazione, String prefix,
  1486.             String schemaCorniceSicurezza, ModIAuditConfig auditConfig) throws ProtocolException {
  1487.         
  1488.         if(schemaCorniceSicurezza!=null && StringUtils.isNotEmpty(schemaCorniceSicurezza) && auditConfig!=null) {
  1489.             readCorniceSicurezzaSchema(objectNode, msg, busta,
  1490.                     erroriValidazione, prefix, auditConfig.getClaims());
  1491.         }
  1492.         
  1493.     }
  1494.     private void readCorniceSicurezzaSchema(ObjectNode objectNode, OpenSPCoop2Message msg, Busta busta,
  1495.             List<Eccezione> erroriValidazione, String prefix,
  1496.             List<ModIAuditClaimConfig> claims) throws ProtocolException {
  1497.         
  1498.         if(claims!=null && !claims.isEmpty()) {
  1499.             for (ModIAuditClaimConfig modIAuditClaimConfig : claims) {
  1500.                 String claimName = modIAuditClaimConfig.getNome();
  1501.                 if(objectNode.has(claimName)) {
  1502.                     Object o = objectNode.get(claimName);
  1503.                     if(o!=null) {
  1504.                         processCorniceSicurezzaSchemaClaimValue(msg, modIAuditClaimConfig, busta,
  1505.                                 erroriValidazione, prefix,
  1506.                                 claimName, o);
  1507.                     }
  1508.                 }
  1509.                 else if(modIAuditClaimConfig.isRequired()){
  1510.                     erroriValidazione.add(this.validazioneUtils.newEccezioneValidazione(CodiceErroreCooperazione.MITTENTE_NON_PRESENTE, 
  1511.                             prefix+getErroreTokenSenzaClaim(claimName)));
  1512.                 }
  1513.             }
  1514.         }
  1515.         
  1516.     }
  1517.     private void processCorniceSicurezzaSchemaClaimValue(OpenSPCoop2Message msg, ModIAuditClaimConfig modIAuditClaimConfig, Busta busta,
  1518.             List<Eccezione> erroriValidazione, String prefix,
  1519.             String claimName, Object o) throws ProtocolException {
  1520.         
  1521.         String v = toString(o);
  1522.         
  1523.         
  1524.         // Trace
  1525.         if(modIAuditClaimConfig.isTrace()) {
  1526.             busta.addProperty(ModICostanti.MODIPA_BUSTA_EXT_PROFILO_SICUREZZA_MESSAGGIO_CORNICE_SICUREZZA_AUDIT_PREFIX+claimName, v);
  1527.         }
  1528.         
  1529.         // Validazione
  1530.         ModIValidazioneAuditClaimValue validator = new ModIValidazioneAuditClaimValue(claimName, v, o, modIAuditClaimConfig);
  1531.         validator.validate(this.validazioneUtils, erroriValidazione, prefix);
  1532.         
  1533.         // Forward
  1534.         String header = modIAuditClaimConfig.getForwardBackend();
  1535.         if(header!=null && StringUtils.isNotEmpty(header)) {
  1536.             msg.forceTransportHeader(header, v);
  1537.         }
  1538.     }   
  1539.     
  1540.     private boolean readCorniceSicurezzaCodiceEnteLegacy(ObjectNode objectNode, Busta busta,
  1541.             List<Eccezione> erroriValidazione, String prefix) throws ProtocolException {
  1542.         
  1543.         boolean readIss = true;
  1544.         
  1545.         String claimNameCodiceEnte = this.modiProperties.getSicurezzaMessaggioCorniceSicurezzaRestCodiceEnte();
  1546.         if(Claims.JSON_WEB_TOKEN_RFC_7519_ISSUER.equals(claimNameCodiceEnte)) {
  1547.             readIss = false;
  1548.         }
  1549.         if(objectNode.has(claimNameCodiceEnte)) {
  1550.             Object codiceEnte = objectNode.get(claimNameCodiceEnte);
  1551.             if(codiceEnte!=null) {
  1552.                 busta.addProperty(ModICostanti.MODIPA_BUSTA_EXT_PROFILO_SICUREZZA_MESSAGGIO_CORNICE_SICUREZZA_CORNICE_SICUREZZA_ENTE, toString(codiceEnte));
  1553.             }
  1554.         }
  1555.         else {
  1556.             erroriValidazione.add(this.validazioneUtils.newEccezioneValidazione(CodiceErroreCooperazione.MITTENTE_NON_PRESENTE, 
  1557.                     prefix+getErroreTokenSenzaClaim(claimNameCodiceEnte)));
  1558.         }
  1559.         
  1560.         return readIss;
  1561.     }
  1562.     
  1563.     private boolean readCorniceSicurezzaUserLegacy(ObjectNode objectNode, Busta busta,
  1564.             List<Eccezione> erroriValidazione, String prefix) throws ProtocolException {
  1565.         
  1566.         boolean readSub = true;
  1567.         
  1568.         String claimNameUser = this.modiProperties.getSicurezzaMessaggioCorniceSicurezzaRestUser();
  1569.         if(Claims.JSON_WEB_TOKEN_RFC_7519_SUBJECT.equals(claimNameUser)) {
  1570.             readSub = false;
  1571.         }
  1572.         if(objectNode.has(claimNameUser)) {
  1573.             Object user = objectNode.get(claimNameUser);
  1574.             if(user!=null) {
  1575.                 busta.addProperty(ModICostanti.MODIPA_BUSTA_EXT_PROFILO_SICUREZZA_MESSAGGIO_CORNICE_SICUREZZA_CORNICE_SICUREZZA_USER, toString(user));
  1576.             }
  1577.         }
  1578.         else {
  1579.             erroriValidazione.add(this.validazioneUtils.newEccezioneValidazione(CodiceErroreCooperazione.MITTENTE_NON_PRESENTE, 
  1580.                     prefix+getErroreTokenSenzaClaim(claimNameUser)));
  1581.         }
  1582.         
  1583.         return readSub;
  1584.         
  1585.     }
  1586.     
  1587.     private void readCorniceSicurezzaIpUserLegacy(ObjectNode objectNode, Busta busta,
  1588.             List<Eccezione> erroriValidazione, String prefix) throws ProtocolException {
  1589.         
  1590.         String claimNameIpUser = this.modiProperties.getSicurezzaMessaggioCorniceSicurezzaRestIpuser();
  1591.         if(objectNode.has(claimNameIpUser)) {
  1592.             Object userIp = objectNode.get(claimNameIpUser);
  1593.             if(userIp!=null) {
  1594.                 busta.addProperty(ModICostanti.MODIPA_BUSTA_EXT_PROFILO_SICUREZZA_MESSAGGIO_CORNICE_SICUREZZA_CORNICE_SICUREZZA_USER_IP, toString(userIp));
  1595.             }
  1596.         }
  1597.         else {
  1598.             erroriValidazione.add(this.validazioneUtils.newEccezioneValidazione(CodiceErroreCooperazione.MITTENTE_NON_PRESENTE, 
  1599.                     prefix+getErroreTokenSenzaClaim(claimNameIpUser)));
  1600.         }
  1601.     }
  1602.     
  1603.     
  1604.     private Date toDate(Object tmp, List<Eccezione> erroriValidazione, CodiceErroreCooperazione codiceErroreCooperazione,String prefix,String claim) throws ProtocolException {
  1605.         try {
  1606.             return toDate(tmp);
  1607.         }catch(Exception e) {
  1608.             erroriValidazione.add(this.validazioneUtils.newEccezioneValidazione(codiceErroreCooperazione, 
  1609.                     prefix+getErroreTokenClaimNonValido(claim,e),e));
  1610.             return null;
  1611.         }
  1612.     }
  1613.     private Date toDate(Object tmp) throws ProtocolException {
  1614.         
  1615.         String tmpV = null;
  1616.         if(tmp==null) {
  1617.             throw new ProtocolException("Value undefined");
  1618.         }
  1619.         if(tmp instanceof String) {
  1620.             tmpV = (String) tmp;
  1621.         }
  1622.         else {
  1623.             tmpV = toString(tmp);
  1624.         }
  1625.         
  1626.         Date d = TokenUtils.parseTimeInSecond(tmpV);
  1627.         if(d!=null) {
  1628.             return d;
  1629.         }
  1630.         
  1631.         throw new ProtocolException("Value '"+tmpV+"' not valid");
  1632.     }
  1633.     
  1634.     private String toString(Object tmp) {
  1635.         if(tmp instanceof TextNode) {
  1636.             TextNode text = (TextNode) tmp;
  1637.             return text.asText();
  1638.         }
  1639.         return tmp.toString();
  1640.     }
  1641. }
Created with JaCoCo 0.8.8.202204050719