ModIImbustamentoRest.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.builder;

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

  32. import org.apache.commons.lang.StringUtils;
  33. import org.openspcoop2.core.constants.CostantiDB;
  34. import org.openspcoop2.core.constants.CostantiLabel;
  35. import org.openspcoop2.core.registry.AccordoServizioParteComune;
  36. import org.openspcoop2.core.registry.Resource;
  37. import org.openspcoop2.message.OpenSPCoop2Message;
  38. import org.openspcoop2.message.constants.MessageRole;
  39. import org.openspcoop2.message.constants.MessageType;
  40. import org.openspcoop2.message.constants.ServiceBinding;
  41. import org.openspcoop2.pdd.core.byok.BYOKUnwrapPolicyUtilities;
  42. import org.openspcoop2.pdd.core.dynamic.DynamicHelperCostanti;
  43. import org.openspcoop2.pdd.core.dynamic.DynamicMapBuilderUtils;
  44. import org.openspcoop2.pdd.core.token.Costanti;
  45. import org.openspcoop2.pdd.core.token.GestoreToken;
  46. import org.openspcoop2.pdd.core.token.parser.Claims;
  47. import org.openspcoop2.protocol.modipa.config.ModIAuditClaimConfig;
  48. import org.openspcoop2.protocol.modipa.config.ModIProperties;
  49. import org.openspcoop2.protocol.modipa.constants.ModICostanti;
  50. import org.openspcoop2.protocol.modipa.constants.ModIHeaderType;
  51. import org.openspcoop2.protocol.modipa.utils.ModIKeystoreConfig;
  52. import org.openspcoop2.protocol.modipa.utils.ModISecurityConfig;
  53. import org.openspcoop2.protocol.modipa.utils.ModIUtilities;
  54. import org.openspcoop2.protocol.modipa.validator.ModIValidazioneAuditClaimValue;
  55. import org.openspcoop2.protocol.sdk.Busta;
  56. import org.openspcoop2.protocol.sdk.Context;
  57. import org.openspcoop2.protocol.sdk.ProtocolException;
  58. import org.openspcoop2.protocol.sdk.RestMessageSecurityToken;
  59. import org.openspcoop2.protocol.sdk.SecurityToken;
  60. import org.openspcoop2.protocol.sdk.constants.RuoloMessaggio;
  61. import org.openspcoop2.protocol.sdk.state.RequestInfo;
  62. import org.openspcoop2.security.keystore.JWKSetStore;
  63. import org.openspcoop2.security.keystore.KeyPairStore;
  64. import org.openspcoop2.security.keystore.MerlinKeystore;
  65. import org.openspcoop2.security.keystore.cache.GestoreKeystoreCache;
  66. import org.openspcoop2.security.message.MessageSecurityContext;
  67. import org.openspcoop2.security.message.MessageSecurityContextParameters;
  68. import org.openspcoop2.security.message.constants.SecurityConstants;
  69. import org.openspcoop2.security.message.engine.MessageSecurityContext_impl;
  70. import org.openspcoop2.security.message.jose.MessageSecuritySender_jose;
  71. import org.openspcoop2.security.message.utils.SignatureBean;
  72. import org.openspcoop2.utils.certificate.CertificateInfo;
  73. import org.openspcoop2.utils.certificate.CertificateUtils;
  74. import org.openspcoop2.utils.certificate.JWKSet;
  75. import org.openspcoop2.utils.certificate.KeystoreType;
  76. import org.openspcoop2.utils.certificate.byok.BYOKRequestParams;
  77. import org.openspcoop2.utils.date.DateManager;
  78. import org.openspcoop2.utils.date.DateUtils;
  79. import org.openspcoop2.utils.digest.DigestEncoding;
  80. import org.openspcoop2.utils.json.JSONUtils;
  81. import org.openspcoop2.utils.random.RandomGenerator;
  82. import org.openspcoop2.utils.transport.TransportUtils;
  83. import org.openspcoop2.utils.transport.http.HttpConstants;
  84. import org.openspcoop2.utils.transport.http.HttpUtilities;
  85. import org.slf4j.Logger;

  87. import com.fasterxml.jackson.databind.node.ArrayNode;
  88. import com.fasterxml.jackson.databind.node.ObjectNode;

  90. /**
  91.  * ModIImbustamentoRest
  92.  *
  93.  * @author Poli Andrea (apoli@link.it)
  94.  * @author $Author$
  95.  * @version $Rev$, $Date$
  96.  */
  97. public class ModIImbustamentoRest {

  99.     private Logger log;
  100.     private ModIProperties modiProperties;
  101.     public ModIImbustamentoRest(Logger log) throws ProtocolException {
  102.         this.log = log;
  103.         this.modiProperties = ModIProperties.getInstance();
  104.     }
  105.     
  106.     public void addSyncInteractionProfile(OpenSPCoop2Message msg, RuoloMessaggio ruoloMessaggio) throws ProtocolException {
  107.     
  108.         if(RuoloMessaggio.RICHIESTA.equals(ruoloMessaggio)) {
  109.             
  110.             // nop
  111.             
  112.         }
  113.         else {
  114.             
  115.             // Flusso di Risposta
  116.             
  117.             String returnCode = null;
  118.             int returnCodeInt = -1;
  119.             if(msg.getTransportResponseContext()!=null) {
  120.                 returnCode = msg.getTransportResponseContext().getCodiceTrasporto();
  121.                 if(returnCode!=null) {
  122.                     try {
  123.                         returnCodeInt = Integer.valueOf(returnCode);
  124.                     }catch(Exception e) {
  125.                         // ignore
  126.                     }
  127.                 }
  128.             }
  129.             
  130.             Integer [] returnCodeAttesi = this.modiProperties.getRestBloccanteHttpStatus();
  131.             
  132.             // Fix: il controllo deve essere fatto solo per i codici che non rientrano in 4xx e 5xx
  133.             boolean is4xx5xx = (returnCodeInt>=400) && (returnCodeInt<=599);
  134.             
  135.             if(!is4xx5xx && returnCodeAttesi!=null) {               
  136.                 boolean found = false;
  137.                 for (Integer integer : returnCodeAttesi) {
  138.                     if(integer.intValue() == ModICostanti.MODIPA_PROFILO_INTERAZIONE_HTTP_CODE_2XX_INT_VALUE) {
  139.                         if((returnCodeInt >= 200) && (returnCodeInt<=299) ) {
  140.                             found = true;
  141.                             break;
  142.                         }
  143.                     }
  144.                     else if(integer.intValue() == returnCodeInt) {
  145.                         found = true;
  146.                         break;
  147.                     }
  148.                 }
  149.                 if(!found) {
  150.                     StringBuilder sb = new StringBuilder();
  151.                     for (Integer integer : returnCodeAttesi) {
  152.                         
  153.                         if(integer.intValue() == ModICostanti.MODIPA_PROFILO_INTERAZIONE_HTTP_CODE_2XX_INT_VALUE) {
  154.                             sb = new StringBuilder();
  155.                             sb.append("2xx");
  156.                             break;
  157.                         }
  158.                         
  159.                         if(sb.length()>0) {
  160.                             sb.append(",");
  161.                         }
  162.                         sb.append(integer.intValue());
  163.                     }
  164.                     ProtocolException pe = new ProtocolException("HTTP Status '"+returnCodeInt+"' differente da quello atteso per il profilo bloccante (atteso: "+sb.toString()+")");
  165.                     pe.setInteroperabilityError(true);
  166.                     throw pe;
  167.                 }
  168.             }
  169.             
  170.         }
  171.         
  172.     }
  173.     
  174.     private static String getHeaderHttpPrefix(String hdr) {
  175.         return "Header http '"+hdr+"'";
  176.     }
  177.     private ProtocolException newProtocolExceptionAccessoKeystoreNonRiuscito(String type,String path) {
  178.         return new ProtocolException("Accesso al keystore ["+type+"] '"+path+"' non riuscito");
  179.     }
  180.     private static final String RICHIESTO_NON_BLOCCANTE_PUSH = ", richiesto dal profilo non bloccante PUSH, non trovato";
  181.     
  182.     public void addAsyncInteractionProfile(OpenSPCoop2Message msg, Busta busta, RuoloMessaggio ruoloMessaggio,
  183.             String asyncInteractionType, String asyncInteractionRole,
  184.             String replyTo,
  185.             AccordoServizioParteComune apiContenenteRisorsa, String azione) throws ProtocolException {
  186.         
  187.         if(RuoloMessaggio.RICHIESTA.equals(ruoloMessaggio)) {
  188.             
  189.             // Flusso di Richiesta
  190.             
  191.             if(ModICostanti.MODIPA_PROFILO_INTERAZIONE_ASINCRONA_VALUE_PUSH.equals(asyncInteractionType)) {
  192.             
  193.                 if(ModICostanti.MODIPA_PROFILO_INTERAZIONE_ASINCRONA_RUOLO_VALUE_RICHIESTA.equals(asyncInteractionRole)) {
  194.                 
  195.                     String headerReplyName = this.modiProperties.getRestReplyToHeader();
  196.                     
  197.                     if(this.modiProperties.isRestSecurityTokenPushReplyToUpdateOrCreateInFruizione()) {
  198.                         msg.getTransportRequestContext().removeHeader(headerReplyName); // rimuovo se già esiste
  199.                         msg.forceTransportHeader(headerReplyName, replyTo);
  200.                         busta.addProperty(ModICostanti.MODIPA_BUSTA_EXT_PROFILO_INTERAZIONE_ASINCRONA_REPLY_TO, replyTo);
  201.                     }
  202.                     else {
  203.                         String replyToFound = msg.getTransportRequestContext().getHeaderFirstValue(headerReplyName);
  204.                         if(replyToFound!=null && !"".equals(replyToFound)) {
  205.                             busta.addProperty(ModICostanti.MODIPA_BUSTA_EXT_PROFILO_INTERAZIONE_ASINCRONA_REPLY_TO, replyToFound);
  206.                         }
  207.                         else {
  208.                             ProtocolException pe = new ProtocolException(getHeaderHttpPrefix(headerReplyName)+RICHIESTO_NON_BLOCCANTE_PUSH);
  209.                             pe.setInteroperabilityError(true);
  210.                             throw pe;
  211.                         }
  212.                     }
  213.                     
  214.                 }
  215.                 else if(ModICostanti.MODIPA_PROFILO_INTERAZIONE_ASINCRONA_RUOLO_VALUE_RISPOSTA.equals(asyncInteractionRole)) {
  216.                     
  217.                     String headerCorrelationId = this.modiProperties.getRestCorrelationIdHeader();
  218.                     
  219.                     String correlationIdFound = msg.getTransportRequestContext().getHeaderFirstValue(headerCorrelationId);
  220.                     
  221.                     if(correlationIdFound!=null && !"".equals(correlationIdFound)) {
  222.                         busta.addProperty(ModICostanti.MODIPA_BUSTA_EXT_PROFILO_INTERAZIONE_ASINCRONA_ID_CORRELAZIONE, correlationIdFound);
  223.                         if(correlationIdFound.length()<=255) {
  224.                             busta.setCollaborazione(correlationIdFound);
  225.                         }
  226.                     }
  227.                     else if(busta.getCollaborazione()!=null) {
  228.                         busta.addProperty(ModICostanti.MODIPA_BUSTA_EXT_PROFILO_INTERAZIONE_ASINCRONA_ID_CORRELAZIONE, busta.getCollaborazione());
  229.                         msg.forceTransportHeader(headerCorrelationId, busta.getCollaborazione());
  230.                     }
  231.                     else if(busta.getRiferimentoMessaggio()!=null) {
  232.                         busta.setCollaborazione(busta.getRiferimentoMessaggio());
  233.                         busta.addProperty(ModICostanti.MODIPA_BUSTA_EXT_PROFILO_INTERAZIONE_ASINCRONA_ID_CORRELAZIONE, busta.getRiferimentoMessaggio());
  234.                         msg.forceTransportHeader(headerCorrelationId, busta.getRiferimentoMessaggio());
  235.                     }
  236.                     else {
  237.                         ProtocolException pe = new ProtocolException(getHeaderHttpPrefix(headerCorrelationId)+RICHIESTO_NON_BLOCCANTE_PUSH);
  238.                         pe.setInteroperabilityError(true);
  239.                         throw pe;
  240.                     }

  242.                 }
  243.                 
  244.             }
  245.             else {
  246.                 
  247.                 // pull
  248.                 if(ModICostanti.MODIPA_PROFILO_INTERAZIONE_ASINCRONA_RUOLO_VALUE_RICHIESTA_STATO.equals(asyncInteractionRole) ||
  249.                         ModICostanti.MODIPA_PROFILO_INTERAZIONE_ASINCRONA_RUOLO_VALUE_RISPOSTA.equals(asyncInteractionRole)) {
  250.                     
  251.                     String urlInvocata = msg.getTransportRequestContext().getFunctionParameters();
  252.                     if(urlInvocata!=null && !"".equals(urlInvocata)) {
  253.                         
  254.                         String resourcePathAzione = null;
  255.                         for (Resource r : apiContenenteRisorsa.getResourceList()) {
  256.                             if(r.getNome().equals(azione)) {
  257.                                 resourcePathAzione = r.getPath();
  258.                                 break;
  259.                             }
  260.                         }
  261.                         
  262.                         if(!urlInvocata.startsWith("/")) {
  263.                             urlInvocata = "/" + urlInvocata;
  264.                         }
  265.                         String correlationIdExtracted = ModIUtilities.extractCorrelationIdFromLocation(resourcePathAzione, urlInvocata, false, this.log);
  266.                         if(correlationIdExtracted!=null && correlationIdExtracted.length()<=255) {
  267.                             busta.setCollaborazione(correlationIdExtracted);
  268.                         }
  269.                     }
  270.                     
  271.                 }
  272.                 
  273.             }
  274.         }
  275.         else {
  276.             
  277.             // Flusso di Risposta
  278.             
  279.             String returnCode = null;
  280.             int returnCodeInt = -1;
  281.             if(msg!=null && msg.getTransportResponseContext()!=null) {
  282.                 returnCode = msg.getTransportResponseContext().getCodiceTrasporto();
  283.                 if(returnCode!=null) {
  284.                     try {
  285.                         returnCodeInt = Integer.valueOf(returnCode);
  286.                     }catch(Exception e) {
  287.                         // ignore
  288.                     }
  289.                 }
  290.             }
  291.             
  292.             // Fix: il controllo deve essere fatto solo per i codici che non rientrano in 4xx e 5xx
  293.             boolean is4xx5xx = (returnCodeInt>=400) && (returnCodeInt<=599);
  294.             
  295.             Integer [] returnCodeAttesi = null;
  296.             
  297.             if(!is4xx5xx) {
  298.                 if(ModICostanti.MODIPA_PROFILO_INTERAZIONE_ASINCRONA_VALUE_PUSH.equals(asyncInteractionType)) {
  299.                     
  300.                     if(ModICostanti.MODIPA_PROFILO_INTERAZIONE_ASINCRONA_RUOLO_VALUE_RICHIESTA.equals(asyncInteractionRole)) {
  301.                     
  302.                         String headerCorrelationId = this.modiProperties.getRestCorrelationIdHeader();
  303.                         
  304.                         String correlationIdFound = msg.getTransportResponseContext().getHeaderFirstValue(headerCorrelationId);
  305.                         if(correlationIdFound!=null && !"".equals(correlationIdFound) && 
  306.                                 !ModICostanti.MODIPA_BUSTA_EXT_PROFILO_INTERAZIONE_ASINCRONA_ID_CORRELAZIONE_AGGIUNTO_PER_CONSENTIRE_VALIDAZIONE_CONTENUTI.equals(correlationIdFound)) {
  307.                             busta.addProperty(ModICostanti.MODIPA_BUSTA_EXT_PROFILO_INTERAZIONE_ASINCRONA_ID_CORRELAZIONE, correlationIdFound);
  308.                             busta.setCollaborazione(correlationIdFound);
  309.                         }
  310.                         else {
  311.                             if(this.modiProperties.isRestSecurityTokenPushCorrelationIdUseTransactionIdIfNotExists()) {
  312.                                 String idTransazione = msg.getTransactionId();
  313.                                 msg.forceTransportHeader(headerCorrelationId, idTransazione);
  314.                                 busta.addProperty(ModICostanti.MODIPA_BUSTA_EXT_PROFILO_INTERAZIONE_ASINCRONA_ID_CORRELAZIONE, idTransazione);
  315.                                 busta.setCollaborazione(idTransazione);
  316.                             }
  317.                             else {
  318.                                 ProtocolException pe = new ProtocolException(getHeaderHttpPrefix(headerCorrelationId)+RICHIESTO_NON_BLOCCANTE_PUSH);
  319.                                 pe.setInteroperabilityError(true);
  320.                                 throw pe;
  321.                             }
  322.                         }
  323.                         
  324.                         returnCodeAttesi = this.modiProperties.getRestNonBloccantePushRequestHttpStatus();
  325.                     }
  326.                     else {
  327.                         
  328.                         returnCodeAttesi = this.modiProperties.getRestNonBloccantePushResponseHttpStatus();
  329.                         
  330.                     }
  331.                     
  332.                 }
  333.                 else {
  334.                     
  335.                     // pull
  336.                     
  337.                     String location = null;
  338.                     String locationHeader = null;
  339.                     
  340.                     if(ModICostanti.MODIPA_PROFILO_INTERAZIONE_ASINCRONA_RUOLO_VALUE_RICHIESTA.equals(asyncInteractionRole) ||
  341.                             ModICostanti.MODIPA_PROFILO_INTERAZIONE_ASINCRONA_RUOLO_VALUE_RICHIESTA_STATO.equals(asyncInteractionRole)) {
  342.                         
  343.                         locationHeader = this.modiProperties.getRestLocationHeader();
  344.                         if(msg!=null &&
  345.                             msg.getTransportResponseContext()!=null) {
  346.                             location = msg.getTransportResponseContext().getHeaderFirstValue(locationHeader);
  347.                         }
  348.                     }
  349.                     
  350.                     if(ModICostanti.MODIPA_PROFILO_INTERAZIONE_ASINCRONA_RUOLO_VALUE_RICHIESTA.equals(asyncInteractionRole)) {
  351.                         if(location==null || "".equals(location)) {
  352.                             ProtocolException pe = new ProtocolException(getHeaderHttpPrefix(locationHeader)+", richiesto dal profilo non bloccante PULL, non trovato");
  353.                             pe.setInteroperabilityError(true);
  354.                             throw pe;
  355.                         }
  356.                         busta.addProperty(ModICostanti.MODIPA_BUSTA_EXT_PROFILO_INTERAZIONE_ASINCRONA_LOCATION, location);
  357.                         
  358.                         String correlationIdExtracted = ModIUtilities.extractCorrelationId(location, apiContenenteRisorsa, azione, asyncInteractionRole, this.log);
  359.                         if(correlationIdExtracted!=null && correlationIdExtracted.length()<=255) {
  360.                             busta.setCollaborazione(correlationIdExtracted);
  361.                         }
  362.                         
  363.                         returnCodeAttesi = this.modiProperties.getRestNonBloccantePullRequestHttpStatus();
  364.                     }
  365.                     else if(ModICostanti.MODIPA_PROFILO_INTERAZIONE_ASINCRONA_RUOLO_VALUE_RICHIESTA_STATO.equals(asyncInteractionRole)) {
  366.                         Integer [] returnCodeResourceReady = this.modiProperties.getRestNonBloccantePullRequestStateOkHttpStatus();
  367.                         boolean isReady = false;
  368.                         for (Integer integer : returnCodeResourceReady) {
  369.                             if(integer.intValue() == returnCodeInt) {
  370.                                 isReady = true;
  371.                                 break;
  372.                             }
  373.                         }
  374.                         
  375.                         if(isReady) {
  376.                             if(location==null || "".equals(location)) {
  377.                                 ProtocolException pe = new ProtocolException(getHeaderHttpPrefix(locationHeader)+", richiesto dal profilo non bloccante PULL, non trovato");
  378.                                 pe.setInteroperabilityError(true);
  379.                                 throw pe;
  380.                             }
  381.                             busta.addProperty(ModICostanti.MODIPA_BUSTA_EXT_PROFILO_INTERAZIONE_ASINCRONA_LOCATION, location);
  382.                             
  383.                             String correlationIdExtracted = ModIUtilities.extractCorrelationId(location, apiContenenteRisorsa, azione, asyncInteractionRole, this.log);
  384.                             if(correlationIdExtracted!=null && correlationIdExtracted.length()<=255) {
  385.                                 busta.setCollaborazione(correlationIdExtracted);
  386.                             }
  387.                             
  388.                             returnCodeAttesi = returnCodeResourceReady;
  389.                         }
  390.                         else {
  391.                             Integer [] returnCodeAttesiNotReady = this.modiProperties.getRestNonBloccantePullRequestStateNotReadyHttpStatus();
  392.                             returnCodeAttesi = new Integer[returnCodeResourceReady.length+returnCodeAttesiNotReady.length];
  393.                             int i = 0;
  394.                             for (int j=0; j < returnCodeAttesiNotReady.length; j++) {
  395.                                 returnCodeAttesi[i] = returnCodeAttesiNotReady[j];
  396.                                 i++;
  397.                             }
  398.                             for (int j=0; j < returnCodeResourceReady.length; j++) {
  399.                                 returnCodeAttesi[i] = returnCodeResourceReady[j];
  400.                                 i++;
  401.                             }
  402.                         }
  403.                     }
  404.                     else {
  405.                         returnCodeAttesi = this.modiProperties.getRestNonBloccantePullResponseHttpStatus();
  406.                     }
  407.                     
  408.                 }
  409.             }
  410.             
  411.             if(returnCodeAttesi!=null) {
  412.                 boolean found = false;
  413.                 for (Integer integer : returnCodeAttesi) {
  414.                     if(integer.intValue() == returnCodeInt) {
  415.                         found = true;
  416.                         break;
  417.                     }
  418.                 }
  419.                 if(!found) {
  420.                     StringBuilder sb = new StringBuilder();
  421.                     for (Integer integer : returnCodeAttesi) {
  422.                         if(sb.length()>0) {
  423.                             sb.append(",");
  424.                         }
  425.                         sb.append(integer.intValue());
  426.                     }
  427.                     ProtocolException pe = new ProtocolException("HTTP Status '"+returnCodeInt+"' differente da quello atteso per il profilo non bloccante '"+asyncInteractionType+"' con ruolo '"+asyncInteractionRole+"' (atteso: "+sb.toString()+")");
  428.                     pe.setInteroperabilityError(true);
  429.                     throw pe;
  430.                 }
  431.             }
  432.         }
  433.         
  434.     }
  435.     
  436.     public ModIJWTToken addToken(OpenSPCoop2Message msg, boolean request, Context context, ModIKeystoreConfig keystoreConfig, ModISecurityConfig securityConfig,
  437.             Busta busta, String securityMessageProfile, boolean useKIDtokenHeader, String headerTokenRest, 
  438.             boolean corniceSicurezza, String corniceSicurezzaPattern, String corniceSicurezzaSchema,
  439.             RuoloMessaggio ruoloMessaggio, boolean includiRequestDigest,
  440.             Long nowParam, String jti, ModIHeaderType headerType, boolean integritaCustom,
  441.             Map<String, Object> dynamicMap, RequestInfo requestInfo,
  442.             String purposeId, boolean sicurezzaRidefinitaOperazione) throws ProtocolException {
  443.                 
  444.         if(busta==null) {
  445.             throw new ProtocolException("Param busta is null");
  446.         }
  447.                 
  448.         boolean integritaX509 = ModICostanti.MODIPA_PROFILO_SICUREZZA_MESSAGGIO_VALUE_IDAM0301.equals(securityMessageProfile) || 
  449.                 ModICostanti.MODIPA_PROFILO_SICUREZZA_MESSAGGIO_VALUE_IDAM0302.equals(securityMessageProfile);
  450.         boolean integritaKid = ModICostanti.MODIPA_PROFILO_SICUREZZA_MESSAGGIO_VALUE_IDAM0401.equals(securityMessageProfile) || 
  451.                 ModICostanti.MODIPA_PROFILO_SICUREZZA_MESSAGGIO_VALUE_IDAM0402.equals(securityMessageProfile);
  452.         boolean integrita = integritaX509 || integritaKid;
  453.         
  454.         if(integrita && integritaCustom) {
  455.             busta.addProperty(ModICostanti.MODIPA_BUSTA_EXT_PROFILO_SICUREZZA_MESSAGGIO_CUSTOM_HEADER,headerTokenRest);
  456.         }
  457.         
  458.         boolean filtroDuplicati = ModICostanti.MODIPA_PROFILO_SICUREZZA_MESSAGGIO_VALUE_IDAM02.equals(securityMessageProfile) || 
  459.                 ModICostanti.MODIPA_PROFILO_SICUREZZA_MESSAGGIO_VALUE_IDAM0302.equals(securityMessageProfile) || 
  460.                 ModICostanti.MODIPA_PROFILO_SICUREZZA_MESSAGGIO_VALUE_IDAM0402.equals(securityMessageProfile);
  461.         
  462.         boolean headerDuplicati = headerType.isHeaderDuplicati();
  463.         boolean headerAuthentication = headerType.isUsabledForAuthentication();
  464.         
  465.         boolean tokenAudit = corniceSicurezza && !CostantiDB.MODIPA_PROFILO_SICUREZZA_MESSAGGIO_CORNICE_SICUREZZA_PATTERN_OLD.equals(corniceSicurezzaPattern) && corniceSicurezzaSchema!=null;
  466.         
  467.         boolean audit02 = tokenAudit && CostantiDB.MODIPA_PROFILO_SICUREZZA_MESSAGGIO_CORNICE_SICUREZZA_PATTERN_AUDIT_REST_02.equals(corniceSicurezzaPattern);
  468.         
  469.         boolean apiSoap = ServiceBinding.SOAP.equals(msg.getServiceBinding());
  470.         
  471.         boolean cacheable = false;
  472.         if(tokenAudit) {
  473.             cacheable = true; // verrà perfezionato sotto rispetto ai claim
  474.         }
  475.         else {
  476.             cacheable = !integrita && !filtroDuplicati; 
  477.         }
  478.         
  479.         String idTransazione = msg.getTransactionId();
  480.         if(idTransazione==null &&
  481.             context!=null && context.containsKey(org.openspcoop2.core.constants.Costanti.ID_TRANSAZIONE)) {
  482.             idTransazione = Context.getValue(org.openspcoop2.core.constants.Costanti.ID_TRANSAZIONE, context);
  483.         }
  484.         
  485.         ModIJWTToken modiToken = new ModIJWTToken(idTransazione);
  486.         String nomePorta = null;
  487.         if(requestInfo!=null && requestInfo.getProtocolContext()!=null) {
  488.             nomePorta = requestInfo.getProtocolContext().getInterfaceName();
  489.         }
  490.         
  491.         ModIJWTTokenClaims modiTokenClaims = new ModIJWTTokenClaims(tokenAudit, idTransazione, request, nomePorta, busta.getAzione(), sicurezzaRidefinitaOperazione);
  492.         modiToken.setClaims(modiTokenClaims);
  493.         
  494.         /*
  495.          * == realizzo token ==
  496.          */
  497.                         
  498.         JSONUtils jsonUtils = JSONUtils.getInstance();
  499.         
  500.         ObjectNode payloadToken = null;
  501.         try {
  502.             payloadToken = jsonUtils.newObjectNode();
  503.         }catch(Exception e) {
  504.             throw new ProtocolException(e.getMessage(),e);
  505.         }
  506.         
  507.         // add iat, nbf, exp
  508.         long nowMs = nowParam!=null ? nowParam.longValue() : DateManager.getTimeMillis();
  509.         long nowSeconds = nowMs/1000;
  510.         Date nowDateUsatoPerProprietaTraccia = new Date((nowSeconds*1000)); // e' inutile che traccio i millisecondi, tanto poi nel token non viaggiano
  511.         
  512.         // iat
  513.         payloadToken.put(Claims.JSON_WEB_TOKEN_RFC_7519_ISSUED_AT, nowSeconds);
  514.         String iatValue = DateUtils.getSimpleDateFormatMs().format(nowDateUsatoPerProprietaTraccia);
  515.         if(!headerDuplicati || HttpConstants.AUTHORIZATION.equalsIgnoreCase(headerTokenRest)) {
  516.             busta.addProperty(tokenAudit ? ModICostanti.MODIPA_BUSTA_EXT_PROFILO_SICUREZZA_MESSAGGIO_CORNICE_SICUREZZA_AUDIT_IAT : ModICostanti.MODIPA_BUSTA_EXT_PROFILO_SICUREZZA_MESSAGGIO_IAT,
  517.                     iatValue);
  518.         }
  519.         else {
  520.             String iatAuthorization = busta.getProperty(ModICostanti.MODIPA_BUSTA_EXT_PROFILO_SICUREZZA_MESSAGGIO_IAT);
  521.             if(!iatValue.equals(iatAuthorization)) {
  522.                 busta.addProperty(ModICostanti.MODIPA_BUSTA_EXT_PROFILO_SICUREZZA_MESSAGGIO_REST_INTEGRITY_IAT, iatValue);
  523.             }
  524.         }
  525.         modiTokenClaims.setIat(nowDateUsatoPerProprietaTraccia);
  526.         modiTokenClaims.setIatValue(iatValue);
  527.         
  528.         // nbf
  529.         payloadToken.put(Claims.JSON_WEB_TOKEN_RFC_7519_NOT_TO_BE_USED_BEFORE, nowSeconds);
  530.         String nbfValue = DateUtils.getSimpleDateFormatMs().format(nowDateUsatoPerProprietaTraccia);
  531.         if(!headerDuplicati || HttpConstants.AUTHORIZATION.equalsIgnoreCase(headerTokenRest)) {
  532.             busta.addProperty(tokenAudit ? ModICostanti.MODIPA_BUSTA_EXT_PROFILO_SICUREZZA_MESSAGGIO_CORNICE_SICUREZZA_AUDIT_NBF : ModICostanti.MODIPA_BUSTA_EXT_PROFILO_SICUREZZA_MESSAGGIO_NBF, 
  533.                     nbfValue);
  534.         }
  535.         else {
  536.             String nbfAuthorization = busta.getProperty(ModICostanti.MODIPA_BUSTA_EXT_PROFILO_SICUREZZA_MESSAGGIO_NBF);
  537.             if(!nbfValue.equals(nbfAuthorization)) {
  538.                 busta.addProperty(ModICostanti.MODIPA_BUSTA_EXT_PROFILO_SICUREZZA_MESSAGGIO_REST_INTEGRITY_NBF, nbfValue);
  539.             }
  540.         }
  541.         modiTokenClaims.setNbf(nowDateUsatoPerProprietaTraccia);
  542.         modiTokenClaims.setNbfValue(nbfValue);
  543.         
  544.         // exp
  545.         long expired = nowSeconds+securityConfig.getTtlSeconds();
  546.         Date expiredDateUsatoPerProprietaTraccia = new Date(expired*1000);
  547.         payloadToken.put(Claims.JSON_WEB_TOKEN_RFC_7519_EXPIRED, expired);
  548.         String expValue = DateUtils.getSimpleDateFormatMs().format(expiredDateUsatoPerProprietaTraccia);
  549.         if(!headerDuplicati || HttpConstants.AUTHORIZATION.equalsIgnoreCase(headerTokenRest)) {
  550.             busta.addProperty(tokenAudit ? ModICostanti.MODIPA_BUSTA_EXT_PROFILO_SICUREZZA_MESSAGGIO_CORNICE_SICUREZZA_AUDIT_EXP : ModICostanti.MODIPA_BUSTA_EXT_PROFILO_SICUREZZA_MESSAGGIO_EXP, 
  551.                     expValue);
  552.         }
  553.         else {
  554.             String expAuthorization = busta.getProperty(ModICostanti.MODIPA_BUSTA_EXT_PROFILO_SICUREZZA_MESSAGGIO_EXP);
  555.             if(!expValue.equals(expAuthorization)) {
  556.                 busta.addProperty(ModICostanti.MODIPA_BUSTA_EXT_PROFILO_SICUREZZA_MESSAGGIO_REST_INTEGRITY_EXP, nbfValue);
  557.             }
  558.         }
  559.         modiToken.setExp(expiredDateUsatoPerProprietaTraccia);
  560.         modiTokenClaims.setExp(expiredDateUsatoPerProprietaTraccia);
  561.         modiTokenClaims.setExpValue(expValue);
  562.         
  563.         // jti
  564.         if(jti!=null) {
  565.             payloadToken.put(Claims.JSON_WEB_TOKEN_RFC_7519_JWT_ID, jti);
  566.             if(tokenAudit) {
  567.                 busta.addProperty(ModICostanti.MODIPA_BUSTA_EXT_PROFILO_SICUREZZA_MESSAGGIO_CORNICE_SICUREZZA_AUDIT_ID, jti);
  568.             }
  569.             else {
  570.                 if(headerDuplicati && (busta==null || !jti.equals(busta.getID()))) {
  571.                     if(integrita) {
  572.                         busta.addProperty(ModICostanti.MODIPA_BUSTA_EXT_PROFILO_SICUREZZA_MESSAGGIO_REST_INTEGRITY_ID, jti);
  573.                     }
  574.                     else {
  575.                         busta.addProperty(ModICostanti.MODIPA_BUSTA_EXT_PROFILO_SICUREZZA_MESSAGGIO_REST_AUTHORIZATION_ID, jti);
  576.                     }
  577.                 }
  578.                 else {
  579.                     busta.addProperty(ModICostanti.MODIPA_BUSTA_EXT_PROFILO_SICUREZZA_MESSAGGIO_ID, jti);
  580.                 }
  581.             }
  582.             modiTokenClaims.setJti(jti);
  583.         }
  584.         
  585.         // audit
  586.         String audience = null;
  587.         if(tokenAudit) {
  588.             audience = securityConfig.getCorniceSicurezzaAudience();
  589.             // sulla richiesta direttamente come valore dinamico, sulla risposta come claims
  590.             try {
  591.                 audience = ModIUtilities.getDynamicValue(ModICostanti.MODIPA_BUSTA_EXT_PROFILO_SICUREZZA_MESSAGGIO_CORNICE_SICUREZZA_AUDIT_AUDIENCE, 
  592.                         audience, dynamicMap, context);
  593.             }catch(Exception e) {
  594.                 this.log.error(e.getMessage(),e);
  595.                 ProtocolException pe = new ProtocolException(e.getMessage());
  596.                 pe.setInteroperabilityError(true);
  597.                 throw pe;
  598.             }
  599.             /**}*/
  600.             /**payloadToken.put(Claims.JSON_WEB_TOKEN_RFC_7519_AUDIENCE, audience);*/
  601.             StringBuilder sbAudience = new StringBuilder();
  602.             addAudienceClaim(jsonUtils, payloadToken, audience, sbAudience);
  603.             String audAuthorization = busta.getProperty(ModICostanti.MODIPA_BUSTA_EXT_PROFILO_SICUREZZA_MESSAGGIO_REST_AUDIENCE);
  604.             String audDaAggiungereInBusta = sbAudience.toString();
  605.             if(audAuthorization==null || !audDaAggiungereInBusta.equals(audAuthorization)) {
  606.                 busta.addProperty(ModICostanti.MODIPA_BUSTA_EXT_PROFILO_SICUREZZA_MESSAGGIO_CORNICE_SICUREZZA_AUDIT_AUDIENCE, audDaAggiungereInBusta);
  607.             }
  608.         }
  609.         else if(securityConfig.getAudience()!=null) {
  610.             audience = securityConfig.getAudience();
  611.             /**if(RuoloMessaggio.RISPOSTA.equals(ruoloMessaggio)) {*/
  612.             // sulla richiesta direttamente come valore dinamico, sulla risposta come claims
  613.             try {
  614.                 audience = ModIUtilities.getDynamicValue(ModICostanti.MODIPA_BUSTA_EXT_PROFILO_SICUREZZA_MESSAGGIO_REST_AUDIENCE, 
  615.                         audience, dynamicMap, context);
  616.             }catch(Exception e) {
  617.                 this.log.error(e.getMessage(),e);
  618.                 ProtocolException pe = new ProtocolException(e.getMessage());
  619.                 pe.setInteroperabilityError(true);
  620.                 throw pe;
  621.             }
  622.             /**}*/
  623.             /**payloadToken.put(Claims.JSON_WEB_TOKEN_RFC_7519_AUDIENCE, audience);*/
  624.             StringBuilder sbAudience = new StringBuilder();
  625.             addAudienceClaim(jsonUtils, payloadToken, audience, sbAudience);
  626.             String audDaAggiungereInBusta = sbAudience.toString();
  627.             if(!headerDuplicati || HttpConstants.AUTHORIZATION.equalsIgnoreCase(headerTokenRest)) {
  628.                 busta.addProperty(ModICostanti.MODIPA_BUSTA_EXT_PROFILO_SICUREZZA_MESSAGGIO_REST_AUDIENCE, audDaAggiungereInBusta);
  629.             }
  630.             else {
  631.                 String audAuthorization = busta.getProperty(ModICostanti.MODIPA_BUSTA_EXT_PROFILO_SICUREZZA_MESSAGGIO_REST_AUDIENCE);
  632.                 if(!audDaAggiungereInBusta.equals(audAuthorization)) {
  633.                     busta.addProperty(ModICostanti.MODIPA_BUSTA_EXT_PROFILO_SICUREZZA_MESSAGGIO_REST_INTEGRITY_AUDIENCE, audDaAggiungereInBusta);
  634.                 }
  635.             }
  636.         }
  637.         modiTokenClaims.setAudience(audience);
  638.         
  639.         // clientId
  640.         boolean addClientId = false;
  641.         if(tokenAudit) {
  642.             if(useKIDtokenHeader) {
  643.                 addClientId = securityConfig.getCorniceSicurezzaSchemaConfig().isClientIdOAuth();
  644.             }
  645.             else {
  646.                 addClientId = securityConfig.getCorniceSicurezzaSchemaConfig().isClientIdLocale();
  647.             }
  648.         }
  649.         else {
  650.             addClientId = true;
  651.         }
  652.         
  653.         String clientId = null;
  654.         boolean clientIdNotGenerate = false;
  655.         if(securityConfig.getClientId()!=null) {
  656.             clientIdNotGenerate = DynamicHelperCostanti.NOT_GENERATE.equalsIgnoreCase(securityConfig.getClientId());
  657.             if(!clientIdNotGenerate) {
  658.                 clientId = securityConfig.getClientId();
  659.             }
  660.             if(tokenAudit) {
  661.                 clientIdNotGenerate = false; // forzo a false dopo averlo usato per l'if precedente: nel token di audit la presenza o meno non viene piloata dai claims custom
  662.             }
  663.         }
  664.         boolean clientIdKid = false;
  665.         if( !clientIdNotGenerate && 
  666.             (integritaKid || useKIDtokenHeader || tokenAudit)
  667.             ) {
  668.             String clientIdIntegritaKid = securityConfig.getTokenClientId();
  669.             if(clientIdIntegritaKid!=null) {
  670.                 try {
  671.                     clientIdIntegritaKid = ModIUtilities.getDynamicValue(tokenAudit ? ModICostanti.MODIPA_BUSTA_EXT_PROFILO_SICUREZZA_MESSAGGIO_CORNICE_SICUREZZA_AUDIT_CLIENT_ID : ModICostanti.MODIPA_BUSTA_EXT_PROFILO_SICUREZZA_MESSAGGIO_REST_CLIENT_ID, 
  672.                             clientIdIntegritaKid, dynamicMap, context);
  673.                 }catch(Exception e) {
  674.                     this.log.error(e.getMessage(),e);
  675.                     ProtocolException pe = new ProtocolException(e.getMessage());
  676.                     pe.setInteroperabilityError(true);
  677.                     throw pe;
  678.                 }
  679.             }
  680.             if(clientIdIntegritaKid!=null && StringUtils.isNotEmpty(clientIdIntegritaKid)) {
  681.                 clientId = clientIdIntegritaKid;
  682.                 clientIdKid = true;
  683.             }
  684.         }
  685.         if(RuoloMessaggio.RISPOSTA.equals(ruoloMessaggio) && clientId!=null && !clientIdKid) {
  686.             try {
  687.                 clientId = ModIUtilities.getDynamicValue(ModICostanti.MODIPA_BUSTA_EXT_PROFILO_SICUREZZA_MESSAGGIO_REST_CLIENT_ID, 
  688.                         clientId, dynamicMap, context);
  689.             }catch(Exception e) {
  690.                 this.log.error(e.getMessage(),e);
  691.                 ProtocolException pe = new ProtocolException(e.getMessage());
  692.                 pe.setInteroperabilityError(true);
  693.                 throw pe;
  694.             }
  695.         }
  696.         if(addClientId && clientId!=null) {
  697.             String claimName = this.modiProperties.getRestSecurityTokenClaimsClientIdHeader(); 
  698.             payloadToken.put(claimName, clientId);
  699.             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, clientId);
  700.             modiTokenClaims.setClientId(clientId);
  701.         }
  702.         
  703.         // kid
  704.         String kid = null;
  705.         if(integritaKid || useKIDtokenHeader) {
  706.             kid = securityConfig.getTokenKid();
  707.             if(kid!=null) {
  708.                 try {
  709.                     kid = ModIUtilities.getDynamicValue(ModICostanti.MODIPA_BUSTA_EXT_PROFILO_SICUREZZA_MESSAGGIO_KID, 
  710.                             kid, dynamicMap, context);
  711.                 }catch(Exception e) {
  712.                     this.log.error(e.getMessage(),e);
  713.                     ProtocolException pe = new ProtocolException(e.getMessage());
  714.                     pe.setInteroperabilityError(true);
  715.                     throw pe;
  716.                 }
  717.                 modiTokenClaims.setKid(kid);
  718.             }
  719.         }
  720.         
  721.         if(RuoloMessaggio.RISPOSTA.equals(ruoloMessaggio)) {
  722.             corniceSicurezza = false; // permessa solo per i messaggi di richiesta
  723.         }
  724.         boolean addIss = true;
  725.         boolean addSub = true;
  726.         
  727.         // requestDigest (integrita)
  728.         if(integrita && RuoloMessaggio.RISPOSTA.equals(ruoloMessaggio) && includiRequestDigest &&
  729.             context.containsKey(ModICostanti.MODIPA_CONTEXT_REQUEST_DIGEST)) {
  730.             Object o = context.getObject(ModICostanti.MODIPA_CONTEXT_REQUEST_DIGEST);
  731.             String value = (String) o;
  732.             String claimNameRequestDigest = this.modiProperties.getRestSecurityTokenClaimRequestDigest();
  733.             payloadToken.put(claimNameRequestDigest, value);
  734.             modiTokenClaims.setRequestDigest(value);
  735.         }
  736.         
  737.         // coriniceSicurezza/auditInfo
  738.         if(corniceSicurezza) {
  739.             
  740.             if(CostantiDB.MODIPA_PROFILO_SICUREZZA_MESSAGGIO_CORNICE_SICUREZZA_PATTERN_OLD.equals(corniceSicurezzaPattern)) {
  741.                 
  742.                 addIss = addCorniceSicurezzaLegacyCodiceEnte(securityConfig,
  743.                         dynamicMap, context,
  744.                         payloadToken, busta,
  745.                         modiTokenClaims);
  746.                 
  747.                 addSub = addCorniceSicurezzaLegacyUser(securityConfig,
  748.                         dynamicMap, context,
  749.                         payloadToken, busta,
  750.                         modiTokenClaims);
  751.                 
  752.                 addCorniceSicurezzaLegacyIpUser(securityConfig,
  753.                         dynamicMap, context,
  754.                         payloadToken, busta,
  755.                         modiTokenClaims);
  756.             }
  757.             else if(tokenAudit){
  758.                 
  759.                 cacheable = addCorniceSicurezzaSchema(securityConfig,
  760.                         dynamicMap, context,
  761.                         payloadToken, busta,
  762.                         corniceSicurezzaSchema,
  763.                         modiTokenClaims);
  764.                 
  765.                 if(corniceSicurezzaSchema!=null && StringUtils.isNotEmpty(corniceSicurezzaSchema)) {
  766.                     if(useKIDtokenHeader) {
  767.                         addIss = securityConfig.getCorniceSicurezzaSchemaConfig().isIssOAuth();
  768.                         addSub = securityConfig.getCorniceSicurezzaSchemaConfig().isSubOAuth();
  769.                     }
  770.                     else {
  771.                         addIss = securityConfig.getCorniceSicurezzaSchemaConfig().isIssLocale();
  772.                         addSub = securityConfig.getCorniceSicurezzaSchemaConfig().isSubLocale();
  773.                     }
  774.                 }
  775.                 
  776.             }
  777.                         
  778.         }
  779.         
  780.         // iss
  781.         if(addIss) {
  782.             String issuer = null;
  783.             if(tokenAudit) {
  784.                 if(clientId==null) {
  785.                     ProtocolException pe = new ProtocolException("ClientId undefined; required in audit token 'iss' claim");
  786.                     pe.setInteroperabilityError(true);
  787.                     throw pe;
  788.                 }
  789.                 issuer = clientId;
  790.             }
  791.             else if(securityConfig.getIssuer()!=null &&
  792.                     !DynamicHelperCostanti.NOT_GENERATE.equalsIgnoreCase(securityConfig.getIssuer())) {
  793.                 try {
  794.                     issuer = ModIUtilities.getDynamicValue(ModICostanti.MODIPA_BUSTA_EXT_PROFILO_SICUREZZA_MESSAGGIO_REST_ISSUER, 
  795.                             securityConfig.getIssuer(), dynamicMap, context);
  796.                 }catch(Exception e) {
  797.                     this.log.error(e.getMessage(),e);
  798.                     ProtocolException pe = new ProtocolException(e.getMessage());
  799.                     pe.setInteroperabilityError(true);
  800.                     throw pe;
  801.                 }
  802.             }
  803.             if(issuer!=null) {
  804.                 payloadToken.put(Claims.INTROSPECTION_RESPONSE_RFC_7662_ISSUER, issuer);
  805.                 busta.addProperty(tokenAudit ? ModICostanti.MODIPA_BUSTA_EXT_PROFILO_SICUREZZA_MESSAGGIO_CORNICE_SICUREZZA_AUDIT_ISSUER : ModICostanti.MODIPA_BUSTA_EXT_PROFILO_SICUREZZA_MESSAGGIO_REST_ISSUER, 
  806.                         issuer);
  807.                 modiTokenClaims.setIss(issuer);
  808.             }
  809.         }
  810.         
  811.         // sub
  812.         if(addSub) {
  813.             String subject = null;
  814.             if(tokenAudit) {
  815.                 if(clientId==null) {
  816.                     ProtocolException pe = new ProtocolException("ClientId undefined; required in audit token 'sub' claim");
  817.                     pe.setInteroperabilityError(true);
  818.                     throw pe;
  819.                 }
  820.                 subject = clientId;
  821.             }
  822.             else if(securityConfig.getSubject()!=null &&
  823.                     !DynamicHelperCostanti.NOT_GENERATE.equalsIgnoreCase(securityConfig.getSubject())) {
  824.                 try {
  825.                     subject = ModIUtilities.getDynamicValue(ModICostanti.MODIPA_BUSTA_EXT_PROFILO_SICUREZZA_MESSAGGIO_REST_SUBJECT, 
  826.                             securityConfig.getSubject(), dynamicMap, context);
  827.                 }catch(Exception e) {
  828.                     this.log.error(e.getMessage(),e);
  829.                     ProtocolException pe = new ProtocolException(e.getMessage());
  830.                     pe.setInteroperabilityError(true);
  831.                     throw pe;
  832.                 }
  833.             }
  834.             if(subject!=null) {
  835.                 payloadToken.put(Claims.INTROSPECTION_RESPONSE_RFC_7662_SUBJECT, subject);
  836.                 busta.addProperty(tokenAudit ? ModICostanti.MODIPA_BUSTA_EXT_PROFILO_SICUREZZA_MESSAGGIO_CORNICE_SICUREZZA_AUDIT_SUBJECT : ModICostanti.MODIPA_BUSTA_EXT_PROFILO_SICUREZZA_MESSAGGIO_REST_SUBJECT, 
  837.                         subject);
  838.                 modiTokenClaims.setSub(subject);
  839.             }
  840.         }
  841.         
  842.         // purposeId
  843.         if(purposeId!=null) {
  844.             boolean addPurposeId = false;
  845.             if(tokenAudit) {
  846.                 addPurposeId = this.modiProperties.isSecurityTokenAuditAddPurposeId();
  847.             }
  848.             else if(integritaX509) {
  849.                 addPurposeId = this.modiProperties.isSecurityTokenIntegrity01AddPurposeId();
  850.             }
  851.             else if(integritaKid) {
  852.                 addPurposeId = this.modiProperties.isSecurityTokenIntegrity02AddPurposeId();
  853.             }
  854.             if(addPurposeId) {
  855.                 String purposeValue = null;
  856.                 try {
  857.                     purposeValue = ModIUtilities.getDynamicValue(tokenAudit ? ModICostanti.MODIPA_BUSTA_EXT_PROFILO_SICUREZZA_MESSAGGIO_CORNICE_SICUREZZA_AUDIT_PURPOSE_ID : ModICostanti.MODIPA_BUSTA_EXT_PROFILO_SICUREZZA_MESSAGGIO_REST_INTEGRITY_PURPOSE_ID, 
  858.                             purposeId, dynamicMap, context);
  859.                 }catch(Exception e) {
  860.                     this.log.error(e.getMessage(),e);
  861.                     ProtocolException pe = new ProtocolException(e.getMessage());
  862.                     pe.setInteroperabilityError(true);
  863.                     throw pe;
  864.                 }
  865.                 if(purposeValue!=null) {
  866.                     payloadToken.put(Costanti.PDND_PURPOSE_ID, purposeValue);
  867.                     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, 
  868.                             purposeValue);
  869.                     modiTokenClaims.setPurposeId(purposeValue);
  870.                 }
  871.             }
  872.         }
  873.         
  874.         if(audit02) {
  875.             
  876.             String dNonce = RandomGenerator.getDefaultInstance().nextRandomInt(this.modiProperties.getSecurityTokenAuditDnonceSize());
  877.             long dNonceInt = Long.parseLong(dNonce);
  878.             payloadToken.put(Costanti.PDND_DNONCE, dNonceInt);
  879.             modiTokenClaims.setdNonce(dNonce);
  880.                 
  881.         }
  882.         
  883.         // custom claims
  884.         Map<String, String> claimsCustom = new HashMap<>();
  885.         if(securityConfig.getMultipleHeaderClaims()!=null && !securityConfig.getMultipleHeaderClaims().isEmpty()) {
  886.             for (Object oKeyP : securityConfig.getMultipleHeaderClaims().keySet()) {
  887.                 if(oKeyP instanceof String) {
  888.                     String key = (String) oKeyP;
  889.                     String value = securityConfig.getMultipleHeaderClaims().getProperty(key);
  890.                     claimsCustom.put(key, value);
  891.                 }
  892.             }
  893.         }
  894.         if(securityConfig.getClaims()!=null && !securityConfig.getClaims().isEmpty()) {
  895.             for (Object oKeyP : securityConfig.getClaims().keySet()) {
  896.                 if(oKeyP instanceof String) {
  897.                     String key = (String) oKeyP;
  898.                     String value = securityConfig.getClaims().getProperty(key);
  899.                     if(!claimsCustom.containsKey(key)) {
  900.                         claimsCustom.put(key, value);
  901.                     }
  902.                 }
  903.             }
  904.         }
  905.         if(!claimsCustom.isEmpty()) {
  906.             
  907.             List<String> blackListRegistrazioneCustomClaims = null;
  908.             boolean tracciaCustomClaims = this.modiProperties.isGenerazioneTracceRegistraCustomClaims();
  909.             if(tracciaCustomClaims) {
  910.                 blackListRegistrazioneCustomClaims = this.modiProperties.getGenerazioneTracceRegistraCustomClaimsBlackList();
  911.             }
  912.             
  913.             for (Map.Entry<String,String> entry : claimsCustom.entrySet()) {
  914.                 String key = entry.getKey();
  915.                 String value =  claimsCustom.get(key);
  916.                 try {
  917.                     value = ModIUtilities.getDynamicValue(CostantiLabel.MODIPA_API_IMPL_PROFILO_SICUREZZA_MESSAGGIO_REST_JWT_CLAIMS_LABEL+" - "+key, 
  918.                             value, dynamicMap, context);
  919.                 }catch(Exception e) {
  920.                     this.log.error(e.getMessage(),e);
  921.                     ProtocolException pe = new ProtocolException(e.getMessage());
  922.                     pe.setInteroperabilityError(true);
  923.                     throw pe;
  924.                 }
  925.                 if(value!=null) {
  926.                     try {
  927.                         jsonUtils.putValue(payloadToken, key, value); // per salvaguardare i tipi
  928.                     }catch(Exception e) {
  929.                         throw new ProtocolException(e.getMessage(),e);
  930.                     }
  931.                     
  932.                     if(tracciaCustomClaims &&
  933.                             (blackListRegistrazioneCustomClaims==null || blackListRegistrazioneCustomClaims.isEmpty() || !blackListRegistrazioneCustomClaims.contains(key))) {
  934.                         busta.addProperty(ModICostanti.MODIPA_BUSTA_EXT_PROFILO_SICUREZZA_MESSAGGIO_REST_CLAIM_PREFIX+key, value);
  935.                     }
  936.                     
  937.                     modiTokenClaims.addCustomClaim(key, value);
  938.                 }
  939.             }
  940.         }
  941.         
  942.                 
  943.         // integrita
  944.         if(integrita && !integritaCustom) {
  945.             
  946.             String digestValue = null;
  947.             boolean hasContent = false;
  948.             try {
  949.                 hasContent = msg.castAsRest().hasContent();
  950.             }catch(Exception e) {
  951.                 throw new ProtocolException(e.getMessage(),e);
  952.             }
  953.             if(hasContent) {
  954.             
  955.                 // Produco Digest Headers
  956.                 try {
  957.                     ByteArrayOutputStream bout = new ByteArrayOutputStream();
  958.                     msg.writeTo(bout, false);
  959.                     bout.flush();
  960.                     bout.close();
  961.                     
  962.                     digestValue = HttpUtilities.getDigestHeaderValue(bout.toByteArray(), securityConfig.getDigestAlgorithm(), securityConfig.getDigestEncoding());
  963.                 }catch(Exception e) {
  964.                     throw new ProtocolException(e.getMessage(),e);
  965.                 }
  966.                 msg.forceTransportHeader(HttpConstants.DIGEST, digestValue);
  967.                 busta.addProperty(ModICostanti.MODIPA_BUSTA_EXT_PROFILO_SICUREZZA_MESSAGGIO_DIGEST, digestValue);
  968.             
  969.             }
  970.                 
  971.             if(securityConfig.getHttpHeaders()!=null && !securityConfig.getHttpHeaders().isEmpty()) {
  972.                 
  973.                 ArrayNode signedHeaders = null;
  974.                 try {
  975.                     signedHeaders = jsonUtils.newArrayNode();
  976.                 }catch(Exception e) {
  977.                     throw new ProtocolException(e.getMessage(),e);
  978.                 }
  979.                 
  980.                 Map<String, List<String>> mapForceTransportHeaders = msg.getForceTransportHeaders();
  981.                 
  982.                 for (String httpHeader : securityConfig.getHttpHeaders()) {
  983.                     
  984.                     ObjectNode httpHeaderNode = null;
  985.                     String hdrName = null;
  986.                     List<String> hdrValues = new ArrayList<>();
  987.                     
  988.                     if(httpHeader.equalsIgnoreCase(HttpConstants.DIGEST)) {
  989.                         if(digestValue!=null) {
  990.                             hdrName = HttpConstants.DIGEST;
  991.                             hdrValues.add(digestValue);
  992.                         }
  993.                         else if(RuoloMessaggio.RISPOSTA.equals(ruoloMessaggio) && msg.getTransportResponseContext()!=null && 
  994.                                 msg.getTransportRequestContext()!=null && org.openspcoop2.utils.transport.http.HttpRequestMethod.HEAD.equals(msg.getTransportRequestContext().getRequestType()) &&
  995.                                 this.modiProperties.isRestSecurityTokenResponseDigestHEADuseServerHeader()) {
  996.                             List<String> digestValueHEAD = msg.getTransportResponseContext().getHeaderValues(HttpConstants.DIGEST);
  997.                             if(digestValueHEAD!=null && !digestValueHEAD.isEmpty()) {
  998.                                 hdrName = HttpConstants.DIGEST;
  999.                                 hdrValues.addAll(digestValueHEAD);
  1000.                             }
  1001.                         }
  1002.                     }
  1003.                     else if(httpHeader.equalsIgnoreCase(HttpConstants.CONTENT_TYPE)) {
  1004.                         // l'engine potrebbe modificarlo (negli spazi o nell'ordine dei caratteri)
  1005.                         String ct = null;
  1006.                         try {
  1007.                             ct = msg.getContentType();
  1008.                         }catch(Exception e) {
  1009.                             throw new ProtocolException(e.getMessage(),e);
  1010.                         }
  1011.                         if(ct!=null) {
  1012.                             hdrName = httpHeader;
  1013.                             hdrValues.add(ct);
  1014.                         }
  1015.                     }
  1016.                     else {
  1017.                         List<String> values = getHeaderValues(ruoloMessaggio, msg, mapForceTransportHeaders, httpHeader);
  1018.                         if(values!=null && !values.isEmpty()) {
  1019.                             hdrName = httpHeader;
  1020.                             hdrValues.addAll(values);
  1021.                         }
  1022.                         
  1023.                     }
  1024.                     if(hdrName!=null) {
  1025.                         for (String hdrValue : hdrValues) {
  1026.                             try {
  1027.                                 httpHeaderNode = jsonUtils.newObjectNode();
  1028.                             }catch(Exception e) {
  1029.                                 throw new ProtocolException(e.getMessage(),e);
  1030.                             }
  1031.                             String hdrNameLowerCase = hdrName.toLowerCase(); // uso come nome dell'header tutto minuscolo come indicato nella specifica, tra gli esempi
  1032.                             httpHeaderNode.put(hdrNameLowerCase, hdrValue); 
  1033.                             if(HttpConstants.AUTHORIZATION.equalsIgnoreCase(hdrNameLowerCase) && headerDuplicati) {
  1034.                                 ModIUtilities.addHeaderProperty(busta, hdrNameLowerCase, HttpConstants.AUTHORIZATION_PREFIX_BEARER +"...TOKEN..."); 
  1035.                             }
  1036.                             else {
  1037.                                 ModIUtilities.addHeaderProperty(busta, hdrNameLowerCase, hdrValue);
  1038.                             }
  1039.                             signedHeaders.add(httpHeaderNode);  
  1040.                         }
  1041.                     }
  1042.                 }
  1043.                 
  1044.                 if(signedHeaders.size()>0) {
  1045.                     String claimSignedHeader = this.modiProperties.getRestSecurityTokenClaimSignedHeaders();
  1046.                     payloadToken.set(claimSignedHeader, signedHeaders);
  1047.                 }
  1048.             }
  1049.         }
  1050.         

  1052.         
  1053.         
  1054.         

  1056.         
  1057.         
  1058.         /*
  1059.          * == signature ==
  1060.          */
  1061.         
  1062.         MessageSecuritySender_jose joseSignature = new MessageSecuritySender_jose();
  1063.         MessageSecurityContextParameters messageSecurityContextParameters = new MessageSecurityContextParameters();
  1064.         MessageSecurityContext messageSecurityContext = new MessageSecurityContext_impl(messageSecurityContextParameters);
  1065.         Map<String,Object> secProperties = new HashMap<>();
  1066.         secProperties.put(SecurityConstants.SECURITY_ENGINE, SecurityConstants.SECURITY_ENGINE_JOSE);
  1067.         secProperties.put(SecurityConstants.ACTION, SecurityConstants.SIGNATURE_ACTION);
  1068.         secProperties.put(SecurityConstants.SIGNATURE_MODE, SecurityConstants.SIGNATURE_MODE_COMPACT);
  1069.         secProperties.put(SecurityConstants.SIGNATURE_DETACHED, SecurityConstants.SIGNATURE_DETACHED_FALSE);
  1070.         secProperties.put(SecurityConstants.JOSE_USE_HEADERS, SecurityConstants.JOSE_USE_HEADERS_TRUE);
  1071.         secProperties.put(SecurityConstants.JOSE_CONTENT_TYPE, SecurityConstants.JOSE_CONTENT_TYPE_FALSE);
  1072.         secProperties.put(SecurityConstants.JOSE_TYPE, org.apache.cxf.rs.security.jose.common.JoseConstants.TYPE_JWT);
  1073.         
  1074.         
  1075.         // algoritmo
  1076.         String algorithm = null;
  1077.         if(tokenAudit && apiSoap) {
  1078.             algorithm = securityConfig.getAlgorithmConvertForREST();
  1079.         }
  1080.         else {
  1081.             algorithm = securityConfig.getAlgorithm();
  1082.         }
  1083.         secProperties.put(SecurityConstants.SIGNATURE_ALGORITHM, algorithm);
  1084.         modiTokenClaims.setAlgorithm(algorithm);
  1085.         
  1086.         
  1087.         // spedizione certificato
  1088.         boolean richiestaConfigurazioneX509 = false;
  1089.         if(integritaKid || useKIDtokenHeader) {
  1090.             if(kid==null) {
  1091.                 // utilizzo l'alias
  1092.                 kid = keystoreConfig.getSecurityMessageKeyAlias();
  1093.                 if(kid==null) {
  1094.                     throw new ProtocolException("Il pattern configurato richiede la definizione di un KID");
  1095.                 }
  1096.             }
  1097.             secProperties.put(SecurityConstants.JOSE_KID_CUSTOM, kid); // kid
  1098.             modiTokenClaims.setKid(kid);
  1099.         }
  1100.         else {
  1101.             
  1102.             richiestaConfigurazioneX509 = true;
  1103.             
  1104.             boolean addKid = tokenAudit ? this.modiProperties.isSecurityTokenAuditX509AddKid() : this.modiProperties.isSecurityTokenX509AddKid();
  1105.             if(addKid) {
  1106.                 secProperties.put(SecurityConstants.JOSE_KID, SecurityConstants.JOSE_KID_TRUE); // kid
  1107.             }
  1108.             modiTokenClaims.setAddKid(addKid);
  1109.             
  1110.             boolean x5c = tokenAudit && apiSoap ? this.modiProperties.isSecurityTokenAuditApiSoapX509RiferimentoX5c() : securityConfig.isX5c();
  1111.             if(x5c) {
  1112.                 secProperties.put(SecurityConstants.JOSE_INCLUDE_CERT, SecurityConstants.JOSE_INCLUDE_CERT_TRUE);
  1113.                 boolean x5cUseSingleCertificate = tokenAudit && apiSoap ? this.modiProperties.isSecurityTokenAuditApiSoapX509RiferimentoX5cSingleCertificate() : securityConfig.isUseSingleCertificate();
  1114.                 if(!x5cUseSingleCertificate) {
  1115.                     secProperties.put(SecurityConstants.JOSE_INCLUDE_CERT_CHAIN, SecurityConstants.JOSE_INCLUDE_CERT_CHAIN_TRUE);
  1116.                 }
  1117.                 modiTokenClaims.setAddX5cChain(!x5cUseSingleCertificate);
  1118.             }
  1119.             modiTokenClaims.setAddX5c(x5c);
  1120.             
  1121.             boolean x5t = tokenAudit && apiSoap ? this.modiProperties.isSecurityTokenAuditApiSoapX509RiferimentoX5t() : securityConfig.isX5t();
  1122.             if(x5t) {
  1123.                 secProperties.put(SecurityConstants.JOSE_INCLUDE_CERT_SHA, SecurityConstants.JOSE_INCLUDE_CERT_SHA_256);
  1124.             }
  1125.             modiTokenClaims.setAddX5t(x5t);
  1126.             
  1127.             boolean x5u = tokenAudit && apiSoap ? this.modiProperties.isSecurityTokenAuditApiSoapX509RiferimentoX5u() : securityConfig.isX5u();
  1128.             if(x5u) {
  1129.                 String url = securityConfig.getX5url();
  1130.                 secProperties.put(SecurityConstants.JOSE_X509_URL, url);
  1131.                 modiTokenClaims.setX5uUrl(url);
  1132.             }
  1133.             modiTokenClaims.setAddX5u(x5u);
  1134.         }
  1135.         
  1136.         SignatureBean signatureBean = new SignatureBean();
  1137.         org.openspcoop2.utils.certificate.KeyStore ks = null;
  1138.         JWKSet jwkSet = null;
  1139.         String keyAlias = keystoreConfig.getSecurityMessageKeyAlias();
  1140.         if(keystoreConfig.getSecurityMessageKeystorePath()!=null || keystoreConfig.isSecurityMessageKeystoreHSM()) {
  1141.             
  1142.             if(richiestaConfigurazioneX509 &&
  1143.                     (CostantiDB.KEYSTORE_TYPE_JWK.equalsIgnoreCase(keystoreConfig.getSecurityMessageKeystoreType()) || CostantiDB.KEYSTORE_TYPE_KEY_PAIR.equalsIgnoreCase(keystoreConfig.getSecurityMessageKeystoreType()))) {
  1144.                 String type = CostantiDB.KEYSTORE_TYPE_KEY_PAIR.equalsIgnoreCase(keystoreConfig.getSecurityMessageKeystoreType()) ? KeystoreType.KEY_PAIR.getLabel() : KeystoreType.JWK_SET.getLabel();
  1145.                 String pattern = tokenAudit ? "audit" : securityMessageProfile;
  1146.                 throw new ProtocolException("Configuration error; pattern '"+pattern+"' require x509 certificate, found '"+type+"' key");
  1147.             }
  1148.             
  1149.             String keystoreByokPolicy = keystoreConfig.getSecurityMessageKeystoreByokPolicy();
  1150.             BYOKRequestParams byokParams = null;
  1151.             try {
  1152.                 byokParams = BYOKUnwrapPolicyUtilities.getBYOKRequestParams(keystoreByokPolicy, dynamicMap);
  1153.             }catch(Exception e) {
  1154.                 throw new ProtocolException(e.getMessage(),e);
  1155.             }
  1156.             
  1157.             if(CostantiDB.KEYSTORE_TYPE_JWK.equalsIgnoreCase(keystoreConfig.getSecurityMessageKeystoreType())) {
  1158.                 try {
  1159.                     JWKSetStore jwtStore = GestoreKeystoreCache.getJwkSetStore(requestInfo, keystoreConfig.getSecurityMessageKeystorePath(), 
  1160.                             byokParams);
  1161.                     if(jwtStore==null) {
  1162.                         throw newProtocolExceptionAccessoKeystoreNonRiuscito(keystoreConfig.getSecurityMessageKeystoreType(),keystoreConfig.getSecurityMessageKeystorePath());
  1163.                     }
  1164.                     jwkSet = jwtStore.getJwkSet();
  1165.                 }catch(Exception e) {
  1166.                     throw new ProtocolException(e.getMessage(),e);
  1167.                 }
  1168.             }
  1169.             else if(CostantiDB.KEYSTORE_TYPE_KEY_PAIR.equalsIgnoreCase(keystoreConfig.getSecurityMessageKeystoreType())) {
  1170.                 try {
  1171.                     KeyPairStore keyPairStore = GestoreKeystoreCache.getKeyPairStore(requestInfo, keystoreConfig.getSecurityMessageKeystorePath(), keystoreConfig.getSecurityMessageKeystorePathPublicKey(), 
  1172.                             keystoreConfig.getSecurityMessageKeyPassword(), keystoreConfig.getSecurityMessageKeystoreKeyAlgorithm(), 
  1173.                             byokParams);
  1174.                     if(keyPairStore==null) {
  1175.                         throw newProtocolExceptionAccessoKeystoreNonRiuscito(keystoreConfig.getSecurityMessageKeystoreType(),keystoreConfig.getSecurityMessageKeystorePath());
  1176.                     }
  1177.                     jwkSet = keyPairStore.getJwkSet();
  1178.                     keyAlias = keyPairStore.getJwkSetKid();
  1179.                 }catch(Exception e) {
  1180.                     throw new ProtocolException(e.getMessage(),e);
  1181.                 }
  1182.             }
  1183.             else {
  1184.                 try {
  1185.                     MerlinKeystore merlinKs = GestoreKeystoreCache.getMerlinKeystore(requestInfo,
  1186.                             keystoreConfig.getSecurityMessageKeystorePath(), keystoreConfig.getSecurityMessageKeystoreType(), 
  1187.                             keystoreConfig.getSecurityMessageKeystorePassword(),
  1188.                             byokParams);
  1189.                     if(merlinKs==null) {
  1190.                         throw newProtocolExceptionAccessoKeystoreNonRiuscito(keystoreConfig.getSecurityMessageKeystoreType(),keystoreConfig.getSecurityMessageKeystorePath());
  1191.                     }
  1192.                     ks = merlinKs.getKeyStore();
  1193.                 }catch(Exception e) {
  1194.                     throw new ProtocolException(e.getMessage(),e);
  1195.                 }
  1196.             }
  1197.         }
  1198.         else {
  1199.             try {
  1200.                 MerlinKeystore merlinKs = GestoreKeystoreCache.getMerlinKeystore(requestInfo,
  1201.                         keystoreConfig.getSecurityMessageKeystoreArchive(), keystoreConfig.getSecurityMessageKeystoreType(), 
  1202.                         keystoreConfig.getSecurityMessageKeystorePassword());
  1203.                 if(merlinKs==null) {
  1204.                     throw new ProtocolException("Accesso al keystore non riuscito");
  1205.                 }
  1206.                 ks = merlinKs.getKeyStore();
  1207.             }catch(Exception e) {
  1208.                 throw new ProtocolException(e.getMessage(),e);
  1209.             }
  1210.         }
  1211.         signatureBean.setKeystore(ks);
  1212.         signatureBean.setJwkSet(jwkSet);
  1213.         signatureBean.setUser(keyAlias);
  1214.         signatureBean.setPassword(keystoreConfig.getSecurityMessageKeyPassword());
  1215.         messageSecurityContext.setSignatureBean(signatureBean);
  1216.         
  1217.         
  1218.         
  1219.         
  1220.         // Aggiungo a traccia informazioni sul certificato utilizzato
  1221.         X509Certificate x509 = null;
  1222.         if(ks!=null) {
  1223.             
  1224.             if(!richiestaConfigurazioneX509 && kid!=null && StringUtils.isNotEmpty(kid)) {
  1225.                 busta.addProperty(tokenAudit ? ModICostanti.MODIPA_BUSTA_EXT_PROFILO_SICUREZZA_MESSAGGIO_CORNICE_SICUREZZA_AUDIT_KID : ModICostanti.MODIPA_BUSTA_EXT_PROFILO_SICUREZZA_MESSAGGIO_KID,
  1226.                         kid);
  1227.             }
  1228.             
  1229.             Certificate certificate = null;
  1230.             try {
  1231.                 certificate = ks.getCertificate(keystoreConfig.getSecurityMessageKeyAlias());
  1232.             }catch(Exception e) {
  1233.                 throw new ProtocolException(e.getMessage(),e);
  1234.             }
  1235.             if(certificate instanceof X509Certificate) {
  1236.                 x509 = (X509Certificate) certificate;
  1237.                 busta.addProperty(tokenAudit ? ModICostanti.MODIPA_BUSTA_EXT_PROFILO_SICUREZZA_MESSAGGIO_CORNICE_SICUREZZA_AUDIT_X509_SUBJECT : ModICostanti.MODIPA_BUSTA_EXT_PROFILO_SICUREZZA_MESSAGGIO_X509_SUBJECT, 
  1238.                         x509.getSubjectX500Principal().toString());
  1239.                 if(x509.getIssuerX500Principal()!=null) {
  1240.                     busta.addProperty(tokenAudit ? ModICostanti.MODIPA_BUSTA_EXT_PROFILO_SICUREZZA_MESSAGGIO_CORNICE_SICUREZZA_AUDIT_X509_ISSUER : ModICostanti.MODIPA_BUSTA_EXT_PROFILO_SICUREZZA_MESSAGGIO_X509_ISSUER, 
  1241.                             x509.getIssuerX500Principal().toString());
  1242.                 }
  1243.                 if(cacheable) {
  1244.                     try {
  1245.                         String pem = CertificateUtils.toPEM(x509);
  1246.                         modiTokenClaims.setPem(pem);
  1247.                     }catch(Exception e) {
  1248.                         throw new ProtocolException("X509 to PEM serialization failed: "+e.getMessage(),e);
  1249.                     }
  1250.                 }
  1251.             }
  1252.         }
  1253.         if(jwkSet!=null) {
  1254.             busta.addProperty(tokenAudit ? ModICostanti.MODIPA_BUSTA_EXT_PROFILO_SICUREZZA_MESSAGGIO_CORNICE_SICUREZZA_AUDIT_KID : ModICostanti.MODIPA_BUSTA_EXT_PROFILO_SICUREZZA_MESSAGGIO_KID,
  1255.                     kid);
  1256.             if(cacheable) {
  1257.                 try {
  1258.                     modiTokenClaims.setJwk(jwkSet.getJson());
  1259.                 }catch(Exception e) {
  1260.                     throw new ProtocolException("JWK to Json serialization failed: "+e.getMessage(),e);
  1261.                 }
  1262.             }
  1263.         }
  1264.         
  1265.         
  1266.         
  1267.         
  1268.         
  1269.         
  1270.         // Se cachable verifico che non esiste già in cache
  1271.         boolean prelevatoDallaCache = false;
  1272.         String funzioneCache = "ModI-"+(tokenAudit?"Audit":"Authorization");
  1273.         String keyCache = null;
  1274.         Date nowCacheDate = null;
  1275.         if(cacheable) {
  1276.             
  1277.             keyCache = modiTokenClaims.toCacheKey();
  1278.             
  1279.             ModIJWTToken moditokenFromCache = null;
  1280.             try {
  1281.                 nowCacheDate = new Date(nowMs);
  1282.                 moditokenFromCache = (ModIJWTToken) GestoreToken.getTokenCacheItem(keyCache, funzioneCache, nowCacheDate);
  1283.             }catch(Exception e) {
  1284.                 throw new ProtocolException(e.getMessage(),e);
  1285.             }
  1286.             if(moditokenFromCache!=null) {
  1287.                 
  1288.                 moditokenFromCache.getClaims().setInfoNonCachableInBusta(busta);
  1289.                 
  1290.                 modiToken = moditokenFromCache;
  1291.                 
  1292.                 prelevatoDallaCache = true;
  1293.             }
  1294.             
  1295.         }
  1296.         
  1297.         
  1298.         if(!prelevatoDallaCache) {

  1300.             // Produco payload da firmare
  1301.             OpenSPCoop2Message payload = null;
  1302.             try {
  1303.                 String jsonPayload = jsonUtils.toString(payloadToken);
  1304.                 payload = msg.getFactory().createMessage(MessageType.JSON, MessageRole.NONE, 
  1305.                     HttpConstants.CONTENT_TYPE_JSON, jsonPayload.getBytes(), null, null).getMessage_throwParseException();
  1306.             }catch(Exception e) {
  1307.                 throw new ProtocolException(e.getMessage(),e);
  1308.             }
  1309.         
  1310.         
  1311.             // firma
  1312.             try {
  1313.                 messageSecurityContext.setOutgoingProperties(secProperties, false);
  1314.             }catch(Exception e) {
  1315.                 throw new ProtocolException(e.getMessage(),e);
  1316.             }
  1317.             try {
  1318.                 DynamicMapBuilderUtils.injectDynamicMap(busta, requestInfo, context, this.log);
  1319.                 joseSignature.process(messageSecurityContext, payload, context);
  1320.             }catch(Exception e) {
  1321.                 throw new ProtocolException(e.getMessage(),e);
  1322.             }
  1323.         
  1324.             /*
  1325.              * == return token ==
  1326.              */
  1327.             
  1328.             ByteArrayOutputStream bout = new ByteArrayOutputStream();
  1329.             try {
  1330.                 payload.writeTo(bout, true);
  1331.                 bout.flush();
  1332.                 bout.close();
  1333.             }catch(Exception e) {
  1334.                 throw new ProtocolException(e.getMessage(),e);
  1335.             }
  1336.             
  1337.             String token = bout.toString();
  1338.             
  1339.             modiToken.setToken(token);
  1340.             
  1341.             
  1342.             
  1343.             
  1344.             if(audit02) {
  1345.                 
  1346.                 // digest per la negoziazione del token
  1347.                 try {
  1348.                 
  1349.                     String digestAlgorithm = this.modiProperties.getSecurityTokenAuditDigestAlgorithm();
  1350.                     String digestAuditValue = org.openspcoop2.utils.digest.DigestUtils.getDigestValue(token.getBytes(), digestAlgorithm, DigestEncoding.HEX, 
  1351.                             false); // se rfc3230 true aggiunge prefisso algoritmo=
  1352.                     modiToken.setDigestAlgorithm(digestAlgorithm);
  1353.                     modiToken.setDigest(digestAuditValue);
  1354.                                         
  1355.                 }catch(Exception e) {
  1356.                     throw new ProtocolException(e.getMessage(),e);
  1357.                 }
  1358.                 
  1359.             }
  1360.             
  1361.             
  1362.             
  1363.             
  1364.             if(cacheable) {
  1365.                 GestoreToken.putTokenCacheItem(modiToken, keyCache, funzioneCache, nowCacheDate); 
  1366.             }
  1367.         }
  1368.         
  1369.         
  1370.         
  1371.         String securityTokenHeader = headerTokenRest;
  1372.         if(HttpConstants.AUTHORIZATION.equalsIgnoreCase(securityTokenHeader)) {
  1373.             msg.forceTransportHeader(securityTokenHeader, HttpConstants.AUTHORIZATION_PREFIX_BEARER+modiToken.getToken());
  1374.         }
  1375.         else {
  1376.             msg.forceTransportHeader(securityTokenHeader, modiToken.getToken());
  1377.         }
  1378.         

  1380.         if(audit02) {
  1381.             
  1382.             // inserisco digest per la negoziazione del token
  1383.             try {
  1384.             
  1385.                 context.put(ModICostanti.MODIPA_CONTEXT_AUDIT_DIGEST, modiToken.getDigest());
  1386.                 context.put(ModICostanti.MODIPA_CONTEXT_AUDIT_DIGEST_ALGO, modiToken.getDigestAlgorithm());
  1387.                 
  1388.             }catch(Exception e) {
  1389.                 throw new ProtocolException(e.getMessage(),e);
  1390.             }
  1391.             
  1392.         }
  1393.         
  1394.         
  1395.         
  1396.         if(request && context!=null) {
  1397.             
  1398.             SecurityToken securityTokenForContext = ModIUtilities.newSecurityToken(context);
  1399.             
  1400.             RestMessageSecurityToken restSecurityToken = new RestMessageSecurityToken();
  1401.             
  1402.             if(x509!=null) {
  1403.                 restSecurityToken.setCertificate(new CertificateInfo(x509, securityTokenHeader));
  1404.             }
  1405.             if(kid!=null) {
  1406.                 restSecurityToken.setKid(kid);
  1407.             }
  1408.             restSecurityToken.setToken(modiToken.getToken());
  1409.             restSecurityToken.setHttpHeaderName(securityTokenHeader);
  1410.             if(tokenAudit) {
  1411.                 securityTokenForContext.setAudit(restSecurityToken);
  1412.             }
  1413.             else if(headerDuplicati) {
  1414.                 if(headerAuthentication) {
  1415.                     securityTokenForContext.setAuthorization(restSecurityToken);
  1416.                 }
  1417.                 else {
  1418.                     securityTokenForContext.setIntegrity(restSecurityToken);    
  1419.                 }
  1420.             }
  1421.             else {
  1422.                 if(HttpConstants.AUTHORIZATION.equalsIgnoreCase(securityTokenHeader)) {
  1423.                     securityTokenForContext.setAuthorization(restSecurityToken);
  1424.                 }
  1425.                 else {
  1426.                     securityTokenForContext.setIntegrity(restSecurityToken);
  1427.                 }
  1428.             }
  1429.             
  1430.         }
  1431.         
  1432.         
  1433.         
  1434.         
  1435.         return modiToken;
  1436.     }
  1437.     
  1438.     private void addAudienceClaim(JSONUtils jsonUtils, ObjectNode payloadToken, String audience, StringBuilder sbAudience) throws ProtocolException {
  1439.         if(audience!=null) {
  1440.             audience = audience.trim();
  1441.             List<String> lArray = ModIUtilities.getArrayStringAsList(audience, true);
  1442.             if(lArray!=null && !lArray.isEmpty()) {
  1443.                 ArrayNode values = null;
  1444.                 try {
  1445.                     values = jsonUtils.newArrayNode();
  1446.                 }catch(Exception e) {
  1447.                     throw new ProtocolException(e.getMessage(),e);
  1448.                 }
  1449.                 sbAudience.append("[");
  1450.                 for (int i = 0; i < lArray.size(); i++) {
  1451.                     String v = lArray.get(i);
  1452.                     values.add(v);  
  1453.                     if(i>0) {
  1454.                         sbAudience.append(",");
  1455.                     }
  1456.                     sbAudience.append("\"").append(v).append("\"");
  1457.                 }
  1458.                 sbAudience.append("]");
  1459.                 payloadToken.set(Claims.JSON_WEB_TOKEN_RFC_7519_AUDIENCE, values);
  1460.                 return;
  1461.             }
  1462.             payloadToken.put(Claims.JSON_WEB_TOKEN_RFC_7519_AUDIENCE, audience);
  1463.             sbAudience.append(audience);
  1464.         }
  1465.     }
  1466.     
  1467.     public static List<String> getHeaderValues(RuoloMessaggio ruoloMessaggio, OpenSPCoop2Message msg, Map<String, List<String>> mapForceTransportHeaders, String httpHeader){
  1468.         List<String> values = null;
  1469.         if(RuoloMessaggio.RICHIESTA.equals(ruoloMessaggio) && msg.getTransportRequestContext()!=null) {
  1470.             values = msg.getTransportRequestContext().getHeaderValues(httpHeader);
  1471.         }
  1472.         else if(RuoloMessaggio.RISPOSTA.equals(ruoloMessaggio) && msg.getTransportResponseContext()!=null) {
  1473.             values = msg.getTransportResponseContext().getHeaderValues(httpHeader);
  1474.         }
  1475.         
  1476.         // guardo anche eventuali header aggiunti tramite trasformazioni e da precedente chiamata di questo metodo (Authorization)
  1477.         // Se presenti sovrascrivono gli header iniziali(metodo forward usato nei connettori)
  1478.         if(mapForceTransportHeaders!=null && !mapForceTransportHeaders.isEmpty()) {
  1479.             List<String> v = TransportUtils.getRawObject(mapForceTransportHeaders, httpHeader);
  1480.             if(v!=null && !v.isEmpty()) {
  1481.                 values = v;
  1482.             }
  1483.         }
  1484.         
  1485.         return values;
  1486.     }
  1487.     
  1488.     private boolean addCorniceSicurezzaSchema(ModISecurityConfig securityConfig,
  1489.             Map<String, Object> dynamicMap, Context context,
  1490.             ObjectNode payloadToken, Busta busta,
  1491.             String corniceSicurezzaSchema,
  1492.             ModIJWTTokenClaims modiTokenClaims) throws ProtocolException {
  1493.         if(corniceSicurezzaSchema!=null && StringUtils.isNotEmpty(corniceSicurezzaSchema)) {
  1494.             return addCorniceSicurezzaSchema(
  1495.                     dynamicMap, context,
  1496.                     payloadToken, busta,
  1497.                     securityConfig.getCorniceSicurezzaSchemaConfig()!=null ? securityConfig.getCorniceSicurezzaSchemaConfig().getClaims() : null,
  1498.                     modiTokenClaims);
  1499.         }
  1500.         return false;
  1501.     }
  1502.     private boolean addCorniceSicurezzaSchema(
  1503.             Map<String, Object> dynamicMap, Context context,
  1504.             ObjectNode payloadToken, Busta busta,
  1505.             List<ModIAuditClaimConfig> schemas,
  1506.             ModIJWTTokenClaims modiTokenClaims) throws ProtocolException {
  1507.         if(schemas!=null && !schemas.isEmpty()) {
  1508.             boolean cacheable = true;
  1509.             for (ModIAuditClaimConfig modIAuditClaimConfig : schemas) {
  1510.                 boolean claimCacheable = addCorniceSicurezzaSchemaRule(dynamicMap, context,
  1511.                         payloadToken, busta,
  1512.                         modIAuditClaimConfig,
  1513.                         modiTokenClaims);
  1514.                 if(!claimCacheable) {
  1515.                     cacheable = false; // ne basta uno
  1516.                 }
  1517.             }
  1518.             return cacheable;
  1519.         }
  1520.         return false;
  1521.     }
  1522.     private boolean addCorniceSicurezzaSchemaRule(Map<String, Object> dynamicMap, Context context,
  1523.             ObjectNode payloadToken, Busta busta,
  1524.             ModIAuditClaimConfig modIAuditClaimConfig,
  1525.             ModIJWTTokenClaims modiTokenClaims) throws ProtocolException {
  1526.         
  1527.         String headerTokenAudit = this.modiProperties.getSecurityTokenHeaderModIAudit();
  1528.         String prefix = "[Token '"+headerTokenAudit+"'] ";
  1529.         
  1530.         String claimName = modIAuditClaimConfig.getNome();
  1531.         ModIValidazioneAuditClaimValue valoreIntegrazione = null;
  1532.         try {
  1533.             List<String> claimRules = modIAuditClaimConfig.getRules();
  1534.             if(claimRules==null || claimRules.isEmpty()) {
  1535.                 throw new ProtocolException("Rules not available for claim '"+claimName+"'");
  1536.             }
  1537.             
  1538.             valoreIntegrazione = readCorniceSicurezzaSchemaPayloadValue(dynamicMap, context,
  1539.                     modIAuditClaimConfig, claimName, claimRules,
  1540.                     prefix);
  1541.             
  1542.         }catch(Exception e) {
  1543.             if(modIAuditClaimConfig.isRequired()) {
  1544.                 this.log.error(e.getMessage(),e);
  1545.                 ProtocolException pe = new ProtocolException(e.getMessage());
  1546.                 pe.setInteroperabilityError(true);
  1547.                 throw pe;
  1548.             }
  1549.             else {
  1550.                 this.log.debug(e.getMessage(),e);
  1551.             }
  1552.         }
  1553.         
  1554.         // Valido il valore
  1555.         try {
  1556.             if(valoreIntegrazione!=null) {
  1557.                 valoreIntegrazione.validate(prefix);
  1558.             }
  1559.         }catch(Exception e) {
  1560.             this.log.error(e.getMessage(),e);
  1561.             ProtocolException pe = new ProtocolException(e.getMessage());
  1562.             pe.setInteroperabilityError(true);
  1563.             throw pe;
  1564.         }
  1565.         
  1566.         // Aggiungo (non dovrebbero succedere errori)
  1567.         try {
  1568.         
  1569.             if(valoreIntegrazione!=null) {
  1570.                 String valore = addCorniceSicurezzaSchemaPayload(payloadToken, 
  1571.                         claimName, valoreIntegrazione,
  1572.                         modiTokenClaims);
  1573.                 
  1574.                 if(modIAuditClaimConfig.isTrace()) {
  1575.                     busta.addProperty(ModICostanti.MODIPA_BUSTA_EXT_PROFILO_SICUREZZA_MESSAGGIO_CORNICE_SICUREZZA_AUDIT_PREFIX+claimName, valore);
  1576.                 }
  1577.                 
  1578.                 return modIAuditClaimConfig.isCacheable();
  1579.             }
  1580.             else {
  1581.                 return !modIAuditClaimConfig.isRequired(); // sarà considerato cacheable se non trovato, poichè essendo l'elemento opzionale non verrà serializzato nel token
  1582.             }
  1583.             
  1584.         }catch(Exception e) {
  1585.             if(this.log!=null) {
  1586.                 this.log.error(e.getMessage(),e);
  1587.             }
  1588.             throw new ProtocolException(e.getMessage());
  1589.         }

  1591.     }
  1592.     
  1593.     private ModIValidazioneAuditClaimValue readCorniceSicurezzaSchemaPayloadValue(Map<String, Object> dynamicMap, Context context,
  1594.             ModIAuditClaimConfig modIAuditClaimConfig, String claimName, List<String> rules,
  1595.             String prefix) throws ProtocolException {
  1596.         String valore = ModIUtilities.getDynamicValue(ModICostanti.MODIPA_PROFILO_SICUREZZA_MESSAGGIO_CORNICE_SICUREZZA_LABEL+" - "+modIAuditClaimConfig.getLabel(), 
  1597.                 rules, dynamicMap, context);
  1598.         
  1599.         return new ModIValidazioneAuditClaimValue(claimName, valore, modIAuditClaimConfig, prefix);
  1600.     }
  1601.     private String addCorniceSicurezzaSchemaPayload(ObjectNode payloadToken, 
  1602.             String claimName, ModIValidazioneAuditClaimValue value,
  1603.             ModIJWTTokenClaims modiTokenClaims) {

  1605.         if(value.getRawObject() instanceof String) {
  1606.             String valore = (String) value.getRawObject();
  1607.             payloadToken.put(claimName, valore);
  1608.         }
  1609.         else {
  1610.             if(value.getRawObject() instanceof Boolean) {
  1611.                 boolean valore = (Boolean) value.getRawObject();
  1612.                 payloadToken.put(claimName, valore);
  1613.             }
  1614.             else if(value.getRawObject() instanceof Double) {
  1615.                 double valore = (Double) value.getRawObject();
  1616.                 payloadToken.put(claimName, valore);
  1617.             }
  1618.             else if(value.getRawObject() instanceof Float) {
  1619.                 float valore = (Float) value.getRawObject();
  1620.                 payloadToken.put(claimName, valore);
  1621.             }
  1622.             else if(value.getRawObject() instanceof Long) {
  1623.                 long valore = (Long) value.getRawObject();
  1624.                 payloadToken.put(claimName, valore);
  1625.             }
  1626.             else if(value.getRawObject() instanceof Integer) {
  1627.                 int valore = (Integer) value.getRawObject();
  1628.                 payloadToken.put(claimName, valore);
  1629.             }
  1630.         }
  1631.         modiTokenClaims.addCorniceSicurezzaAudit(claimName, value.getValore());
  1632.         
  1633.         return value.getValore();
  1634.     }
  1635.     
  1636.     private boolean addCorniceSicurezzaLegacyCodiceEnte(ModISecurityConfig securityConfig,
  1637.             Map<String, Object> dynamicMap, Context context,
  1638.             ObjectNode payloadToken, Busta busta,
  1639.             ModIJWTTokenClaims modiTokenClaims) throws ProtocolException {
  1640.         
  1641.         boolean addIss = true;
  1642.         
  1643.         String claimNameCodiceEnte = this.modiProperties.getSicurezzaMessaggioCorniceSicurezzaRestCodiceEnte();
  1644.         if(Claims.INTROSPECTION_RESPONSE_RFC_7662_ISSUER.equals(claimNameCodiceEnte)) {
  1645.             addIss = false;
  1646.         }
  1647.         String codiceEnte = null;
  1648.         try {
  1649.             codiceEnte = ModIUtilities.getDynamicValue(ModICostanti.MODIPA_PROFILO_SICUREZZA_MESSAGGIO_CORNICE_SICUREZZA_LABEL+" - "+ModICostanti.MODIPA_PROFILO_SICUREZZA_MESSAGGIO_CORNICE_SICUREZZA_CODICE_ENTE_MODE_LABEL, 
  1650.                     securityConfig.getCorniceSicurezzaCodiceEnteRule(), dynamicMap, context);
  1651.         }catch(Exception e) {
  1652.             this.log.error(e.getMessage(),e);
  1653.             ProtocolException pe = new ProtocolException(e.getMessage());
  1654.             pe.setInteroperabilityError(true);
  1655.             throw pe;
  1656.         }
  1657.         payloadToken.put(claimNameCodiceEnte, codiceEnte);
  1658.         busta.addProperty(ModICostanti.MODIPA_BUSTA_EXT_PROFILO_SICUREZZA_MESSAGGIO_CORNICE_SICUREZZA_CORNICE_SICUREZZA_ENTE, codiceEnte);
  1659.         modiTokenClaims.addCorniceSicurezzaAudit(claimNameCodiceEnte, codiceEnte);
  1660.         
  1661.         return addIss;
  1662.         
  1663.     }
  1664.     
  1665.     private boolean addCorniceSicurezzaLegacyUser(ModISecurityConfig securityConfig,
  1666.             Map<String, Object> dynamicMap, Context context,
  1667.             ObjectNode payloadToken, Busta busta,
  1668.             ModIJWTTokenClaims modiTokenClaims) throws ProtocolException {
  1669.         
  1670.         boolean addSub = true;
  1671.         
  1672.         String claimNameUser = this.modiProperties.getSicurezzaMessaggioCorniceSicurezzaRestUser();
  1673.         if(Claims.INTROSPECTION_RESPONSE_RFC_7662_SUBJECT.equals(claimNameUser)) {
  1674.             addSub = false;
  1675.         }
  1676.         String utente = null;
  1677.         try {
  1678.             utente = ModIUtilities.getDynamicValue(ModICostanti.MODIPA_PROFILO_SICUREZZA_MESSAGGIO_CORNICE_SICUREZZA_LABEL+" - "+ModICostanti.MODIPA_PROFILO_SICUREZZA_MESSAGGIO_CORNICE_SICUREZZA_USER_MODE_LABEL,
  1679.                     securityConfig.getCorniceSicurezzaUserRule(), dynamicMap, context);
  1680.         }catch(Exception e) {
  1681.             this.log.error(e.getMessage(),e);
  1682.             ProtocolException pe = new ProtocolException(e.getMessage());
  1683.             pe.setInteroperabilityError(true);
  1684.             throw pe;
  1685.         }
  1686.         payloadToken.put(claimNameUser, utente);
  1687.         busta.addProperty(ModICostanti.MODIPA_BUSTA_EXT_PROFILO_SICUREZZA_MESSAGGIO_CORNICE_SICUREZZA_CORNICE_SICUREZZA_USER, utente);
  1688.         modiTokenClaims.addCorniceSicurezzaAudit(claimNameUser, utente);
  1689.         
  1690.         return addSub;
  1691.         
  1692.     }
  1693.         
  1694.     private void addCorniceSicurezzaLegacyIpUser(ModISecurityConfig securityConfig,
  1695.             Map<String, Object> dynamicMap, Context context,
  1696.             ObjectNode payloadToken, Busta busta,
  1697.             ModIJWTTokenClaims modiTokenClaims) throws ProtocolException {
  1698.     
  1699.         String claimNameIpUser = this.modiProperties.getSicurezzaMessaggioCorniceSicurezzaRestIpuser();
  1700.         String indirizzoIpPostazione = null;
  1701.         try {
  1702.             indirizzoIpPostazione = ModIUtilities.getDynamicValue(ModICostanti.MODIPA_PROFILO_SICUREZZA_MESSAGGIO_CORNICE_SICUREZZA_LABEL+" - "+ModICostanti.MODIPA_PROFILO_SICUREZZA_MESSAGGIO_CORNICE_SICUREZZA_IP_USER_MODE_LABEL,
  1703.                     securityConfig.getCorniceSicurezzaIpUserRule(), dynamicMap, context);
  1704.         }catch(Exception e) {
  1705.             this.log.error(e.getMessage(),e);
  1706.             ProtocolException pe = new ProtocolException(e.getMessage());
  1707.             pe.setInteroperabilityError(true);
  1708.             throw pe;
  1709.         }
  1710.         payloadToken.put(claimNameIpUser, indirizzoIpPostazione);
  1711.         busta.addProperty(ModICostanti.MODIPA_BUSTA_EXT_PROFILO_SICUREZZA_MESSAGGIO_CORNICE_SICUREZZA_CORNICE_SICUREZZA_USER_IP, indirizzoIpPostazione);
  1712.         modiTokenClaims.addCorniceSicurezzaAudit(claimNameIpUser, indirizzoIpPostazione);
  1713.     }
  1714. }
Created with JaCoCo 0.8.8.202204050719