ModIValidazioneSintatticaSoap.java

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

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

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

  32. import javax.xml.soap.AttachmentPart;
  33. import javax.xml.soap.SOAPEnvelope;
  34. import javax.xml.soap.SOAPHeaderElement;

  36. import org.apache.commons.lang.StringUtils;
  37. import org.apache.wss4j.dom.WSDataRef;
  38. import org.apache.wss4j.dom.message.token.Timestamp;
  39. import org.openspcoop2.core.config.PortaApplicativa;
  40. import org.openspcoop2.core.constants.CostantiLabel;
  41. import org.openspcoop2.core.id.IDPortaApplicativa;
  42. import org.openspcoop2.message.OpenSPCoop2Message;
  43. import org.openspcoop2.message.OpenSPCoop2MessageFactory;
  44. import org.openspcoop2.message.OpenSPCoop2SoapMessage;
  45. import org.openspcoop2.message.soap.reference.Reference;
  46. import org.openspcoop2.message.soap.wsaddressing.Costanti;
  47. import org.openspcoop2.message.soap.wsaddressing.WSAddressingHeader;
  48. import org.openspcoop2.message.soap.wsaddressing.WSAddressingUtilities;
  49. import org.openspcoop2.message.xml.MessageDynamicNamespaceContextFactory;
  50. import org.openspcoop2.message.xml.XPathExpressionEngine;
  51. import org.openspcoop2.pdd.config.OpenSPCoop2Properties;
  52. import org.openspcoop2.pdd.core.dynamic.DynamicUtils;
  53. import org.openspcoop2.pdd.logger.MsgDiagnostico;
  54. import org.openspcoop2.protocol.modipa.builder.ModIImbustamentoSoap;
  55. import org.openspcoop2.protocol.modipa.config.ModIProperties;
  56. import org.openspcoop2.protocol.modipa.constants.ModICostanti;
  57. import org.openspcoop2.protocol.modipa.utils.ModISecurityConfig;
  58. import org.openspcoop2.protocol.modipa.utils.ModITruststoreConfig;
  59. import org.openspcoop2.protocol.modipa.utils.ModIUtilities;
  60. import org.openspcoop2.protocol.modipa.utils.SOAPInfo;
  61. import org.openspcoop2.protocol.sdk.Busta;
  62. import org.openspcoop2.protocol.sdk.Context;
  63. import org.openspcoop2.protocol.sdk.Eccezione;
  64. import org.openspcoop2.protocol.sdk.IProtocolFactory;
  65. import org.openspcoop2.protocol.sdk.ProtocolException;
  66. import org.openspcoop2.protocol.sdk.SecurityToken;
  67. import org.openspcoop2.protocol.sdk.SoapMessageSecurityToken;
  68. import org.openspcoop2.protocol.sdk.constants.CodiceErroreCooperazione;
  69. import org.openspcoop2.protocol.sdk.state.IState;
  70. import org.openspcoop2.protocol.sdk.state.RequestInfo;
  71. import org.openspcoop2.protocol.sdk.validator.ValidazioneUtils;
  72. import org.openspcoop2.security.keystore.KeystoreConstants;
  73. import org.openspcoop2.security.message.MessageSecurityContext;
  74. import org.openspcoop2.security.message.MessageSecurityContextParameters;
  75. import org.openspcoop2.security.message.SubErrorCodeSecurity;
  76. import org.openspcoop2.security.message.constants.SecurityConstants;
  77. import org.openspcoop2.security.message.constants.SignatureDigestAlgorithm;
  78. import org.openspcoop2.security.message.constants.WSSAttachmentsConstants;
  79. import org.openspcoop2.security.message.engine.MessageSecurityContext_impl;
  80. import org.openspcoop2.security.message.saml.SAMLBuilderConfigConstants;
  81. import org.openspcoop2.security.message.wss4j.MessageSecurityReceiver_wss4j;
  82. import org.openspcoop2.utils.certificate.CertificateInfo;
  83. import org.openspcoop2.utils.date.DateUtils;
  84. import org.openspcoop2.utils.io.Base64Utilities;
  85. import org.openspcoop2.utils.xml.DynamicNamespaceContext;
  86. import org.openspcoop2.utils.xml.XPathNotFoundException;
  87. import org.openspcoop2.utils.xml.XPathReturnType;
  88. import org.slf4j.Logger;
  89. import org.w3c.dom.NodeList;

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

  100.     public ModIValidazioneSintatticaSoap(Logger log, IState state, Context context, IProtocolFactory<?> factory, RequestInfo requestInfo,
  101.             ModIProperties modiProperties, ValidazioneUtils validazioneUtils) {
  102.         super(log, state, context, factory, requestInfo, modiProperties, validazioneUtils);
  103.     }
  104.     
  105.     private void logError(String msg) {
  106.         this.log.error(msg);
  107.     }
  108.     private void logError(String msg, Exception e) {
  109.         this.log.error(msg,e);
  110.     }
  111.     
  112.     private String getErrorHeaderSoapNonPresente(String hdr) {
  113.         return "Header SOAP '"+hdr+"' non presente";
  114.     }
  115.     
  116.     public void validateAsyncInteractionProfile(OpenSPCoop2Message msg, boolean request, String asyncInteractionType, String asyncInteractionRole, 
  117.             Busta busta, List<Eccezione> erroriValidazione,
  118.             String replyTo) throws ProtocolException {
  119.         
  120.         boolean bufferMessageReadOnly = this.modiProperties.isValidazioneBufferEnabled();
  121.         String idTransazione = null;
  122.         if(this.context!=null) {
  123.             idTransazione = (String)this.context.getObject(org.openspcoop2.core.constants.Costanti.ID_TRANSAZIONE);
  124.         }
  125.         
  126.         OpenSPCoop2SoapMessage soapMessage = null;
  127.         try {
  128.             soapMessage = msg.castAsSoap();
  129.         }catch(Exception e) {
  130.             throw new ProtocolException(e.getMessage(),e);
  131.         }
  132.         
  133.         String correlationIdName = this.modiProperties.getSoapCorrelationIdName();
  134.         String correlationId = ModIUtilities.getSOAPHeaderCorrelationIdValue(soapMessage, bufferMessageReadOnly, idTransazione);
  135.         
  136.         String replyToName = this.modiProperties.getSoapReplyToName();
  137.         String replyToAddress = ModIUtilities.getSOAPHeaderReplyToValue(soapMessage, bufferMessageReadOnly, idTransazione);

  139.         
  140.         if(replyToAddress!=null) {
  141.             busta.addProperty(ModICostanti.MODIPA_BUSTA_EXT_PROFILO_INTERAZIONE_ASINCRONA_REPLY_TO, replyToAddress);
  142.         }
  143.         if(correlationId!=null) {
  144.             busta.addProperty(ModICostanti.MODIPA_BUSTA_EXT_PROFILO_INTERAZIONE_ASINCRONA_ID_CORRELAZIONE, correlationId);
  145.             if(correlationId.length()<=255) {
  146.                 busta.setCollaborazione(correlationId);
  147.             }
  148.         }
  149.         
  150.         if(asyncInteractionType!=null) {
  151.             if(ModICostanti.MODIPA_PROFILO_INTERAZIONE_ASINCRONA_VALUE_PUSH.equals(asyncInteractionType)) {
  152.                 if(ModICostanti.MODIPA_PROFILO_INTERAZIONE_ASINCRONA_RUOLO_VALUE_RICHIESTA.equals(asyncInteractionRole)) {
  153.                     if(request) {
  154.                         if(replyToAddress==null || "".equals(replyToAddress)) {
  155.                             erroriValidazione.add(this.validazioneUtils.newEccezioneValidazione(CodiceErroreCooperazione.SERVIZIO_CORRELATO_NON_PRESENTE, 
  156.                                     getErrorHeaderSoapNonPresente(replyToName)));
  157.                         }
  158.                         if(this.modiProperties.isSoapSecurityTokenPushReplyToUpdateInErogazione()) {
  159.                             ModIUtilities.addSOAPHeaderReplyTo(soapMessage, bufferMessageReadOnly, idTransazione, replyTo); // aggiorna il valore se già esistente
  160.                         }
  161.                     }
  162.                     else {
  163.                         if(correlationId==null || "".equals(correlationId)) {
  164.                             erroriValidazione.add(this.validazioneUtils.newEccezioneValidazione(CodiceErroreCooperazione.COLLABORAZIONE_NON_PRESENTE, 
  165.                                     getErrorHeaderSoapNonPresente(correlationIdName)));
  166.                         }
  167.                     }
  168.                 }
  169.                 else {
  170.                     if(request &&
  171.                         (correlationId==null || "".equals(correlationId)) 
  172.                         ){
  173.                         erroriValidazione.add(this.validazioneUtils.newEccezioneValidazione(CodiceErroreCooperazione.COLLABORAZIONE_NON_PRESENTE, 
  174.                                 getErrorHeaderSoapNonPresente(correlationIdName)));
  175.                     }
  176.                 }
  177.             }
  178.             else {
  179.                 // pull
  180.                 if(request) {
  181.                     
  182.                     // Flusso di richiesta
  183.                     
  184.                     if( 
  185.                             (
  186.                                     ModICostanti.MODIPA_PROFILO_INTERAZIONE_ASINCRONA_RUOLO_VALUE_RICHIESTA_STATO.equals(asyncInteractionRole) 
  187.                                     ||
  188.                                     ModICostanti.MODIPA_PROFILO_INTERAZIONE_ASINCRONA_RUOLO_VALUE_RISPOSTA.equals(asyncInteractionRole)
  189.                             )
  190.                             &&
  191.                             (correlationId==null || "".equals(correlationId))
  192.                         ){
  193.                         erroriValidazione.add(this.validazioneUtils.newEccezioneValidazione(CodiceErroreCooperazione.COLLABORAZIONE_NON_PRESENTE, 
  194.                                 getErrorHeaderSoapNonPresente(correlationIdName))); 
  195.                     }
  196.                     
  197.                     
  198.                 }
  199.                 else {
  200.                     
  201.                     // Flusso di risposta
  202.                     
  203.                     if(ModICostanti.MODIPA_PROFILO_INTERAZIONE_ASINCRONA_RUOLO_VALUE_RICHIESTA.equals(asyncInteractionRole) &&
  204.                         (correlationId==null || "".equals(correlationId)) 
  205.                     ){
  206.                         erroriValidazione.add(this.validazioneUtils.newEccezioneValidazione(CodiceErroreCooperazione.COLLABORAZIONE_NON_PRESENTE, 
  207.                                 getErrorHeaderSoapNonPresente(correlationIdName)));
  208.                     }
  209.                     
  210.                 }
  211.             }
  212.         }
  213.         
  214.     }
  215.     
  216.     public SOAPEnvelope validateSecurityProfile(OpenSPCoop2Message msg, boolean request, String securityMessageProfile, boolean corniceSicurezza, boolean includiRequestDigest, boolean signAttachments, 
  217.             Busta busta, List<Eccezione> erroriValidazione,
  218.             ModITruststoreConfig trustStoreCertificati, ModISecurityConfig securityConfig,
  219.             boolean buildSecurityTokenInRequest,
  220.             Map<String, Object> dynamicMapParameter, Busta datiRichiesta, RequestInfo requestInfo, MsgDiagnostico msgDiag) throws ProtocolException {
  221.         
  222.         if(msg==null) {
  223.             throw new ProtocolException("Param msg is null");
  224.         }
  225.         
  226.         MessageSecurityContextParameters messageSecurityContextParameters = new MessageSecurityContextParameters();
  227.         messageSecurityContextParameters.setFunctionAsClient(false);
  228.         messageSecurityContextParameters.setPrefixWsuId(OpenSPCoop2Properties.getInstance().getPrefixWsuId()); // NOTA: deve essere lo stesso di govway usato in altri profili
  229.         MessageSecurityContext messageSecurityContext = new MessageSecurityContext_impl(messageSecurityContextParameters);
  230.         
  231.         boolean attesoSecurityHeader = true;
  232.         if(!request) {
  233.             try {
  234.                 if(msg.isFault()) {
  235.                     attesoSecurityHeader = false;
  236.                 }
  237.             }catch(Exception e) {
  238.                 throw new ProtocolException(e.getMessage(),e);
  239.             }
  240.         }
  241.         
  242.         boolean bufferMessageReadOnly = this.modiProperties.isValidazioneBufferEnabled();
  243.         String idTransazione = null;
  244.         if(this.context!=null) {
  245.             idTransazione = (String)this.context.getObject(org.openspcoop2.core.constants.Costanti.ID_TRANSAZIONE);
  246.         }
  247.         
  248.                 
  249.         if(!messageSecurityContext.existsSecurityHeader(msg, this.modiProperties.getSoapSecurityTokenActor(),
  250.                 bufferMessageReadOnly, idTransazione)){
  251.             if(attesoSecurityHeader) {
  252.                 erroriValidazione.add(this.validazioneUtils.newEccezioneValidazione(CodiceErroreCooperazione.SICUREZZA_FIRMA_NON_PRESENTE, 
  253.                         "Header Message Security non riscontrato nella SOAPEnvelope ricevuta"));
  254.             }
  255.             return null;
  256.         }
  257.         
  258.         OpenSPCoop2SoapMessage soapMessage = null;
  259.         try {
  260.             soapMessage = msg.castAsSoap();
  261.         }catch(Exception e) {
  262.             throw new ProtocolException(e.getMessage(),e);
  263.         }
  264.         SOAPInfo soapInfo = new SOAPInfo();
  265.         boolean useSoapReader = false; // i riferimenti recuperati (header, requestDigestHeader, wsAddressing vengono salvati nel contesto per poi eliminarli successivamente)
  266.         try {
  267.             soapInfo.read(useSoapReader, soapMessage, bufferMessageReadOnly, idTransazione, true, true, false);
  268.         }catch(Exception e) {
  269.             throw new ProtocolException(e.getMessage(),e);
  270.         }
  271.         
  272.         boolean filtroDuplicati = ModICostanti.MODIPA_PROFILO_SICUREZZA_MESSAGGIO_VALUE_IDAM02.equals(securityMessageProfile) || 
  273.                 ModICostanti.MODIPA_PROFILO_SICUREZZA_MESSAGGIO_VALUE_IDAM0302.equals(securityMessageProfile) || 
  274.                 ModICostanti.MODIPA_PROFILO_SICUREZZA_MESSAGGIO_VALUE_IDAM0402.equals(securityMessageProfile);
  275.         
  276.         boolean integritaX5c = false;
  277.         if(ModICostanti.MODIPA_PROFILO_SICUREZZA_MESSAGGIO_VALUE_IDAM0301.equals(securityMessageProfile) ||
  278.                 ModICostanti.MODIPA_PROFILO_SICUREZZA_MESSAGGIO_VALUE_IDAM0302.equals(securityMessageProfile)) {
  279.             integritaX5c = true;
  280.         }
  281.         boolean integritaKid = false;
  282.         if(ModICostanti.MODIPA_PROFILO_SICUREZZA_MESSAGGIO_VALUE_IDAM0401.equals(securityMessageProfile) ||
  283.                 ModICostanti.MODIPA_PROFILO_SICUREZZA_MESSAGGIO_VALUE_IDAM0402.equals(securityMessageProfile)) {
  284.             integritaKid = true;
  285.         }
  286.         boolean integrita = integritaX5c || integritaKid;
  287.         
  288.         if(integritaKid) {
  289.             String labelPattern = ModICostanti.MODIPA_PROFILO_SICUREZZA_MESSAGGIO_VALUE_IDAM0401.equals(securityMessageProfile) ?
  290.                     CostantiLabel.MODIPA_PROFILO_SICUREZZA_MESSAGGIO_LABEL_IDAM0401_REST :
  291.                     CostantiLabel.MODIPA_PROFILO_SICUREZZA_MESSAGGIO_LABEL_IDAM0402_REST;
  292.             throw new ProtocolException("Sicurezza Messaggio con pattern '"+labelPattern+"' non utilizzabile su API SOAP");
  293.         }

  295.         /*
  296.          * == requestDigest ==
  297.          */
  298.         
  299.         SOAPHeaderElement requestDigestHeader = null;
  300.         if(integrita && !request && includiRequestDigest) {
  301.             requestDigestHeader = ModIUtilities.getSOAPHeaderRequestDigest(useSoapReader, soapMessage, bufferMessageReadOnly, idTransazione);
  302.         }
  303.         
  304.         
  305.         /*
  306.          * == signature ==
  307.          */
  308.         
  309.         X509Certificate x509 = null;
  310.         List<Reference> elementsToClean = null;
  311.         SOAPHeaderElement securityHeader = null;
  312.         Timestamp timestamp = null;
  313.         WSDataRef timestamptRef = null;
  314.         WSDataRef wsaToRef = null;
  315.         WSDataRef wsaMessageIdRef = null;
  316.         WSDataRef bodyRef = null;
  317.         WSDataRef requestDigestRef = null;
  318.         List<WSDataRef> attachmentsRef = new ArrayList<>();
  319.         MessageSecurityReceiver_wss4j wss4jSignature = null;
  320.         try {
  321.         
  322.             wss4jSignature = new MessageSecurityReceiver_wss4j();
  323.             Map<String,Object> secProperties = new HashMap<>();
  324.             secProperties.put(SecurityConstants.SECURITY_ENGINE, SecurityConstants.SECURITY_ENGINE_WSS4J);
  325.             if(this.modiProperties.getSoapSecurityTokenActor()!=null && !"".equals(this.modiProperties.getSoapSecurityTokenActor())) {
  326.                 secProperties.put(SecurityConstants.ACTOR, this.modiProperties.getSoapSecurityTokenActor());
  327.             }
  328.             secProperties.put(SecurityConstants.MUST_UNDERSTAND, this.modiProperties.isSoapSecurityTokenMustUnderstand()+"");
  329.             
  330.             // cornice sicurezza
  331.             if(!request) {
  332.                 corniceSicurezza = false; // permessa solo per i messaggi di richiesta
  333.             }
  334.             if(corniceSicurezza) {
  335.                 addValidationCorniceSicurezza(secProperties);
  336.             }
  337.             
  338.             // action
  339.             StringBuilder bfAction = new StringBuilder();
  340.             bfAction.append(SecurityConstants.TIMESTAMP_ACTION).append(" ").append(SecurityConstants.SIGNATURE_ACTION);
  341.             if(corniceSicurezza) {
  342.                 bfAction.append(" ").append(SecurityConstants.ACTION_SAML_TOKEN_UNSIGNED);
  343.             }
  344.             secProperties.put(SecurityConstants.ACTION, bfAction.toString());
  345.                         
  346.             // parti attese come firmate
  347.             // La funzionalità solleva errori se trova anche altre parti firmate non attese.
  348.             // Implemento questo controllo tramite i WSDataRef
  349.             /**
  350.             StringBuilder bf = new StringBuilder();
  351.             bf.append("{Element}{http://docs.oasis-open.org/wss/2004/01/oasis-200401-wss-wssecurity-utility-1.0.xsd}Timestamp");
  352.             bf.append(";");
  353.             bf.append("{Element}{").append(Costanti.WSA_NAMESPACE).append("}").append(Costanti.WSA_SOAP_HEADER_TO);
  354.             if(filtroDuplicati) {
  355.                 bf.append(";");
  356.                 bf.append("{Element}{").append(Costanti.WSA_NAMESPACE).append("}").append(Costanti.WSA_SOAP_HEADER_ID);
  357.             }
  358.             if(integrita) {
  359.                 bf.append(";");
  360.                 bf.append("{Element}{").append(soapEnvelope.getNamespaceURI()).append("}Body");
  361.                 if(signAttachments) {
  362.                     if(bf.length()>0) {
  363.                         bf.append(";");
  364.                     }
  365.                     bf.append("{}"+SecurityConstants.CID_ATTACH_WSS4j);
  366.                 }
  367.             }
  368.             if(addCorniceSicurezza) {
  369.                 bf.append(";");
  370.                 bf.append("{Element}{").append(Costanti.SAML_20_NAMESPACE).append("}Assertion");
  371.             }
  372.             secProperties.put(SecurityConstants.SIGNATURE_PARTS, bf.toString());
  373.             secProperties.put(SecurityConstants.SIGNATURE_PARTS_VERIFY, SecurityConstants.TRUE);
  374.             */
  375.             
  376.             // truststore
  377.             Properties pTruststore = new Properties();
  378.             /**pTruststore.put(KeystoreConstants.PROPERTY_PROVIDER, KeystoreConstants.PROVIDER_DEFAULT);*/
  379.             pTruststore.put(KeystoreConstants.PROPERTY_PROVIDER, KeystoreConstants.PROVIDER_GOVWAY);
  380.             pTruststore.put(KeystoreConstants.PROPERTY_TRUSTSTORE_TYPE, trustStoreCertificati.getSecurityMessageTruststoreType());
  381.             if(trustStoreCertificati.getSecurityMessageTruststorePassword()!=null) {
  382.                 pTruststore.put(KeystoreConstants.PROPERTY_TRUSTSTORE_PASSWORD, trustStoreCertificati.getSecurityMessageTruststorePassword());
  383.             }
  384.             pTruststore.put(KeystoreConstants.PROPERTY_TRUSTSTORE_PATH, trustStoreCertificati.getSecurityMessageTruststorePath());
  385.             pTruststore.put(KeystoreConstants.PROPERTY_REQUEST_INFO, requestInfo);
  386.             if(trustStoreCertificati.getSecurityMessageTruststoreCRLs()!=null) {
  387.                 pTruststore.put(KeystoreConstants.PROPERTY_CRL, trustStoreCertificati.getSecurityMessageTruststoreCRLs());
  388.                 secProperties.put(SecurityConstants.ENABLE_REVOCATION, SecurityConstants.TRUE);
  389.             }
  390.             if(trustStoreCertificati.getSecurityMessageTruststoreOCSPPolicy()!=null) {
  391.                 secProperties.put(SecurityConstants.SIGNATURE_OCSP, trustStoreCertificati.getSecurityMessageTruststoreOCSPPolicy());
  392.                 if(trustStoreCertificati.getSecurityMessageTruststoreCRLs()!=null) {
  393.                     secProperties.put(SecurityConstants.SIGNATURE_CRL, trustStoreCertificati.getSecurityMessageTruststoreCRLs());
  394.                 }
  395.             }
  396.             secProperties.put(SecurityConstants.SIGNATURE_VERIFICATION_PROPERTY_REF_ID, pTruststore);
  397.             if(corniceSicurezza) {
  398.                 secProperties.put(SecurityConstants.SIGNATURE_PROPERTY_REF_ID, pTruststore);
  399.             }
  400.             secProperties.put(SecurityConstants.IS_BSP_COMPLIANT, SecurityConstants.TRUE);
  401.             
  402.             
  403.             //  ** Timestamp **
  404.             Long timeToLive = this.modiProperties.getSoapSecurityTokenTimestampCreatedTimeCheckMilliseconds(); // viene usato per vedere la data di creazione quanto si discosta da adesso
  405.             if(securityConfig.getCheckTtlIatMilliseconds()!=null) {
  406.                 timeToLive = securityConfig.getCheckTtlIatMilliseconds();
  407.             }
  408.             boolean setTimeToLive = false;
  409.             if(timeToLive!=null &&
  410.                 msg!=null) {
  411.                 msg.addContextProperty(ModICostanti.MODIPA_OPENSPCOOP2_MSG_CONTEXT_IAT_TTL_CHECK, timeToLive);
  412.                 // Non imposto il valore qua, ma inseriro un valoro alto (3650 giorni) in modo che la libreria non effettui il controllo, che invece avviene nella validazione semantica
  413.                 // In modo da uniformare l'errore rispetto anche a REST
  414.                 /**
  415.                 int value = timeToLive.intValue();
  416.                 if(value>=1000) {
  417.                     value = value / 1000; // riporto in secondi
  418.                     secProperties.put(SecurityConstants.TIMESTAMP_TTL, value+"");
  419.                     set_TimeToLive = true;
  420.                 }*/
  421.             }
  422.             if(!setTimeToLive) {
  423.                 // devo impostare un valore alto, altrimenti il default di wss4j e' 60 secondi
  424.                 // 3650 giorni (60s * 60m * 24h * 3650 giorni = 315360000)
  425.                 secProperties.put(SecurityConstants.TIMESTAMP_TTL, 315360000+"");
  426.             }
  427.             
  428.             Long futureTimeToLive = this.modiProperties.getSoapSecurityTokenTimestampCreatedTimeCheckFutureToleranceMilliseconds();
  429.             if(futureTimeToLive!=null) {
  430.                 // Non imposto il valore qua, in modo che la libreria non effettui il controllo, che invece avviene nella validazione semantica
  431.                 /**
  432.                 long value = futureTimeToLive.longValue();
  433.                 if(value>=1000) {
  434.                     value = value / 1000l; // riporto in secondi
  435.                     secProperties.put(SecurityConstants.TIMESTAMP_FUTURE_TTL, value+"");
  436.                 }
  437.                 */
  438.             }
  439.             
  440.             // disabilito qua la validazione, in modo da implementarla sulla validazione semantica
  441.             // In modo da uniformare l'errore rispetto anche a REST
  442.             secProperties.put(SecurityConstants.TIMESTAMP_STRICT, false+"");
  443.             
  444.             
  445.             // setProperties
  446.             messageSecurityContext.setIncomingProperties(secProperties, false);
  447.             if(signAttachments) {
  448.                 messageSecurityContext.setManualAttachmentsSignaturePart("{}"+SecurityConstants.CID_ATTACH_WSS4J);
  449.             }
  450.             
  451.             
  452.             // ** Raccolgo elementi "toccati" da Security per pulirli poi in fase di sbustamento ** /
  453.             elementsToClean = wss4jSignature.getDirtyElements(messageSecurityContext, soapMessage);
  454.             
  455.             
  456.             // ** Verifica firma elementi richiesti dalla configurazione ** /
  457.             List<SubErrorCodeSecurity> listaErroriRiscontrati = new ArrayList<>();
  458.             wss4jSignature.checkEncryptSignatureParts(messageSecurityContext,elementsToClean, soapMessage,listaErroriRiscontrati);
  459.             if(!listaErroriRiscontrati.isEmpty()){
  460.                 StringBuilder bf = new StringBuilder();
  461.                 for (Iterator<?> iterator = listaErroriRiscontrati.iterator(); iterator.hasNext();) {
  462.                     SubErrorCodeSecurity subCodiceErroreSicurezza = (SubErrorCodeSecurity) iterator.next();
  463.                     if(bf.length()>0){
  464.                         bf.append(" ; ");
  465.                     }
  466.                     bf.append(subCodiceErroreSicurezza.getMsgErrore());
  467.                 }
  468.                 erroriValidazione.add(this.validazioneUtils.newEccezioneValidazione(CodiceErroreCooperazione.SICUREZZA_FIRMA_NON_PRESENTE, 
  469.                         bf.toString()));
  470.                 return null;
  471.             }
  472.             
  473.             
  474.             // ** Applico sicurezza tramite engine **/
  475.             wss4jSignature.process(messageSecurityContext, soapMessage, busta, 
  476.                     bufferMessageReadOnly, idTransazione, this.context);
  477.             
  478.             
  479.             // ** Leggo certificato client **/
  480.             x509 = wss4jSignature.getX509Certificate();
  481.         
  482.             
  483.             // ** Leggo security header **/
  484.             securityHeader = messageSecurityContext.getSecurityHeader(msg, this.modiProperties.getSoapSecurityTokenActor(), 
  485.                     bufferMessageReadOnly, idTransazione);
  486.             timestamp = wss4jSignature.getTimestamp();
  487.             List<WSDataRef> signatureRefs = wss4jSignature.getSignatureRefs();  
  488.             if(signatureRefs!=null && !signatureRefs.isEmpty()) {
  489.                 for (WSDataRef wsDataRef : signatureRefs) {
  490.                     
  491.                     if(wsDataRef.getName()!=null && wsDataRef.getName().getLocalPart()!=null && wsDataRef.getName().getNamespaceURI()!=null) {
  492.                         busta.addProperty(ModICostanti.MODIPA_BUSTA_EXT_PROFILO_SICUREZZA_MESSAGGIO_SIGNED_SOAP_PREFIX+wsDataRef.getName().getLocalPart(), wsDataRef.getName().getNamespaceURI());
  493.                     }
  494.                     
  495.                     if(wsDataRef.getName()!=null && 
  496.                             "Timestamp".equals(wsDataRef.getName().getLocalPart()) &&
  497.                             "http://docs.oasis-open.org/wss/2004/01/oasis-200401-wss-wssecurity-utility-1.0.xsd".equals(wsDataRef.getName().getNamespaceURI())) {
  498.                         timestamptRef = wsDataRef;
  499.                     }
  500.                     else if(wsDataRef.getName()!=null && 
  501.                             Costanti.WSA_SOAP_HEADER_TO.equals(wsDataRef.getName().getLocalPart()) &&
  502.                             Costanti.WSA_NAMESPACE.equals(wsDataRef.getName().getNamespaceURI())) {
  503.                         wsaToRef = wsDataRef;
  504.                     }
  505.                     else if(wsDataRef.getName()!=null && 
  506.                             Costanti.WSA_SOAP_HEADER_ID.equals(wsDataRef.getName().getLocalPart()) &&
  507.                             Costanti.WSA_NAMESPACE.equals(wsDataRef.getName().getNamespaceURI())) {
  508.                         wsaMessageIdRef = wsDataRef;
  509.                     }
  510.                     else if(wsDataRef.getName()!=null && 
  511.                             "Body".equals(wsDataRef.getName().getLocalPart()) &&
  512.                             soapInfo.getEnvelopeNamespace().equals(wsDataRef.getName().getNamespaceURI())) {
  513.                         bodyRef = wsDataRef;
  514.                     }
  515.                     else if(requestDigestHeader!=null &&
  516.                             wsDataRef.getName()!=null && 
  517.                             requestDigestHeader.getLocalName().equals(wsDataRef.getName().getLocalPart()) &&
  518.                             requestDigestHeader.getNamespaceURI().equals(wsDataRef.getName().getNamespaceURI())) {
  519.                         requestDigestRef = wsDataRef;
  520.                     }
  521.                     else if(wsDataRef.getName()!=null && 
  522.                             "attachment".equals(wsDataRef.getName().getLocalPart()) &&
  523.                             WSSAttachmentsConstants.SWA_NS.equals(wsDataRef.getName().getNamespaceURI())) {
  524.                         attachmentsRef.add(wsDataRef);
  525.                     }
  526. /**                 else {
  527. //                      System.out.println("TROVATO ALTRO WS DATA Name["+wsDataRef.getName()+"] wsuId["+wsDataRef.getWsuId()+"]");
  528. //                  }*/
  529.                 }
  530.             }
  531.             
  532.         }catch(Exception e) {
  533.             this.logError("Errore durante la validazione del token di sicurezza: "+e.getMessage(),e);
  534.             erroriValidazione.add(this.validazioneUtils.newEccezioneValidazione(CodiceErroreCooperazione.SICUREZZA_FIRMA_NON_VALIDA, 
  535.                     e.getMessage(),e));
  536.             return null;
  537.         }
  538.         
  539.                 
  540.         if(x509==null || x509.getSubjectX500Principal()==null) {
  541.             erroriValidazione.add(this.validazioneUtils.newEccezioneValidazione(
  542.                     request ? CodiceErroreCooperazione.SERVIZIO_APPLICATIVO_FRUITORE_NON_PRESENTE :
  543.                         CodiceErroreCooperazione.SERVIZIO_APPLICATIVO_EROGATORE_NON_PRESENTE, 
  544.                     "Certificato X509 mittente non presente"));
  545.         }
  546.         else {
  547.             busta.addProperty(ModICostanti.MODIPA_BUSTA_EXT_PROFILO_SICUREZZA_MESSAGGIO_X509_SUBJECT, x509.getSubjectX500Principal().toString());
  548.             if(x509.getIssuerX500Principal()!=null) {
  549.                 busta.addProperty(ModICostanti.MODIPA_BUSTA_EXT_PROFILO_SICUREZZA_MESSAGGIO_X509_ISSUER, x509.getIssuerX500Principal().toString());
  550.             }
  551.             
  552.             if(request) {
  553.                 if(msg==null || msg.getTransportRequestContext()==null || msg.getTransportRequestContext().getInterfaceName()==null) {
  554.                     throw new ProtocolException("ID Porta non presente");
  555.                 }
  556.                 IDPortaApplicativa idPA = new IDPortaApplicativa();
  557.                 idPA.setNome(msg.getTransportRequestContext().getInterfaceName());
  558.                 PortaApplicativa pa = null;
  559.                 try {
  560.                     pa = this.factory.getCachedConfigIntegrationReader(this.state, this.requestInfo).getPortaApplicativa(idPA);
  561.                 }catch(Exception e) {
  562.                     throw new ProtocolException(e.getMessage(),e);
  563.                 }
  564.                 boolean autenticazioneToken = pa!=null && pa.getGestioneToken()!=null && pa.getGestioneToken().getPolicy()!=null && StringUtils.isNotEmpty(pa.getGestioneToken().getPolicy());
  565.                 if(autenticazioneToken) {
  566.                     // l'autenticazione dell'applicativo mittente avviene per token
  567.                     // Il token rappresenta un integrity
  568.                 }
  569.                 else {
  570.                     identificazioneApplicativoMittente(x509,msg,busta,msgDiag);
  571.                 }
  572.             }
  573.         }
  574.         
  575.         SoapMessageSecurityToken soapSecurityToken = null;
  576.         if(request && this.context!=null) {
  577.             
  578.             SecurityToken securityTokenForContext = ModIUtilities.newSecurityToken(this.context);
  579.             
  580.             soapSecurityToken = new SoapMessageSecurityToken();
  581.             soapSecurityToken.setCertificate(new CertificateInfo(x509, "soapEnvelope"));
  582.             //soapSecurityToken.setToken(token); // imposto in fondo a questo metodo        
  583.             securityTokenForContext.setEnvelope(soapSecurityToken);
  584.             
  585.         }
  586.         
  587.         // NOTA: Inizializzare da qua il dynamicMap altrimenti non ci finisce l'identificazione del mittente effettuata dal metodo sopra 'identificazioneApplicativoMittente'
  588.         Map<String, Object> dynamicMap = null;
  589.         Map<String, Object> dynamicMapRequest = null;
  590.         if(!request) {
  591.             dynamicMapRequest = ModIUtilities.removeDynamicMapRequest(this.context);
  592.         }
  593.         try {
  594.             if(dynamicMapRequest!=null) {
  595.                 dynamicMap = DynamicUtils.buildDynamicMapResponse(msg, this.context, null, this.log, bufferMessageReadOnly, dynamicMapRequest);
  596.             }
  597.             else {
  598.                 dynamicMap = DynamicUtils.buildDynamicMap(msg, this.context, datiRichiesta, this.log, bufferMessageReadOnly);
  599.                 ModIUtilities.saveDynamicMapRequest(this.context, dynamicMap);
  600.             }
  601.         }catch(Exception e) {
  602.             throw new ProtocolException(e.getMessage(),e);
  603.         }
  604.         if(dynamicMapParameter!=null && dynamicMap!=null) {
  605.             dynamicMapParameter.putAll(dynamicMap);
  606.         }
  607.         
  608.     
  609.         if(timestamp==null) {
  610.             erroriValidazione.add(this.validazioneUtils.newEccezioneValidazione(CodiceErroreCooperazione.ORA_REGISTRAZIONE_NON_PRESENTE, 
  611.                     "Header WSSecurity Timestamp"));
  612.         }
  613.         else {
  614.             
  615.             if(timestamptRef==null || timestamptRef.getDigestValue()==null || timestamptRef.getDigestAlgorithm()==null) {
  616.                 erroriValidazione.add(this.validazioneUtils.newEccezioneValidazione(CodiceErroreCooperazione.ORA_REGISTRAZIONE_NON_VALIDA, 
  617.                         "Header WSSecurity Timestamp non firmato"));
  618.             }
  619.             else {
  620.                 
  621.                 if(timestamp.getCreated()!=null) {
  622.                     long ms = timestamp.getCreated().toEpochMilli();
  623.                     Date d = new Date(ms); // la conversione serve a risolvere il timezone
  624.                     busta.addProperty(ModICostanti.MODIPA_BUSTA_EXT_PROFILO_SICUREZZA_MESSAGGIO_IAT, DateUtils.getSimpleDateFormatMs().format(d));
  625.                 }
  626.                 else {
  627.                     erroriValidazione.add(this.validazioneUtils.newEccezioneValidazione(CodiceErroreCooperazione.ORA_REGISTRAZIONE_NON_PRESENTE, 
  628.                             "Header WSSecurity Timestamp; elemento 'Created'"));
  629.                 }
  630.                 if(timestamp.getExpires()!=null) {
  631.                     long ms = timestamp.getExpires().toEpochMilli();
  632.                     Date d = new Date(ms); // la conversione serve a risolvere il timezone
  633.                     busta.addProperty(ModICostanti.MODIPA_BUSTA_EXT_PROFILO_SICUREZZA_MESSAGGIO_EXP, DateUtils.getSimpleDateFormatMs().format(d));
  634.                 }
  635.                 else {
  636.                     erroriValidazione.add(this.validazioneUtils.newEccezioneValidazione(CodiceErroreCooperazione.SCADENZA_NON_PRESENTE, 
  637.                             "Header WSSecurity Timestamp; elemento 'Expires'"));
  638.                 }
  639.                 
  640.             }
  641.             
  642.         }
  643.         
  644.         
  645.         if(integrita) {
  646.             if(bodyRef==null || bodyRef.getDigestValue()==null || bodyRef.getDigestAlgorithm()==null) {
  647.                 erroriValidazione.add(this.validazioneUtils.newEccezioneValidazione(CodiceErroreCooperazione.PROFILO_TRASMISSIONE_NON_VALIDO, 
  648.                         "Header WSSecurity Signature; SOAP Body non firmato"));
  649.             }
  650.             else {
  651.                 SignatureDigestAlgorithm s = SignatureDigestAlgorithm.toEnumConstant(bodyRef.getDigestAlgorithm());
  652.                 String digestValue = s!=null ? (s.name()+"=") : "";
  653.                 /**System.out.println("In Hex: "+org.apache.commons.codec.binary.Hex.encodeHexString(bodyRef.getDigestValue()));*/
  654.                 digestValue = digestValue + Base64Utilities.encodeAsString(bodyRef.getDigestValue());
  655.                 busta.addProperty(ModICostanti.MODIPA_BUSTA_EXT_PROFILO_SICUREZZA_MESSAGGIO_DIGEST, digestValue);
  656.                 
  657.                 if(request && includiRequestDigest && this.context!=null && securityHeader!=null) {
  658.                     
  659.                     String digestNamespace = "http://www.w3.org/2000/09/xmldsig#";
  660.                     String digestReferencePattern = "//{"+digestNamespace+"}:Reference";
  661.                     OpenSPCoop2MessageFactory messageFactory = msg!=null ? msg.getFactory() : OpenSPCoop2MessageFactory.getDefaultMessageFactory();
  662.                     DynamicNamespaceContext dnc = MessageDynamicNamespaceContextFactory.getInstance(messageFactory).getNamespaceContext(securityHeader);
  663.                     XPathExpressionEngine xpathEngine = new XPathExpressionEngine(messageFactory);
  664.                     
  665.                     Object res = null;
  666.                     try {
  667.                         res = xpathEngine.getMatchPattern(securityHeader, dnc, digestReferencePattern, XPathReturnType.NODESET);
  668.                     }catch(XPathNotFoundException notFound) {
  669.                         // ignore
  670.                     }catch(Exception e) {
  671.                         throw new ProtocolException(e.getMessage(),e);
  672.                     }
  673.                     if(res!=null) {
  674.                         if(res instanceof NodeList) {
  675.                             NodeList nodeList = (NodeList) res;
  676.                             this.context.addObject(ModICostanti.MODIPA_CONTEXT_REQUEST_DIGEST, nodeList);
  677.                         }
  678.                         else {
  679.                             this.logError("Tipo non gestito ritornato dal xpath engine durante la raccolta delle signature references ["+res.getClass().getName()+"]");
  680.                         }
  681.                     }
  682.                 }
  683.             }
  684.             
  685.             if(!request && includiRequestDigest) {
  686.                 if(requestDigestHeader==null) {
  687.                     erroriValidazione.add(this.validazioneUtils.newEccezioneValidazione(CodiceErroreCooperazione.PROFILO_TRASMISSIONE_NON_VALIDO, 
  688.                             "Header Request Digest non presente"));
  689.                 }
  690.                 if(requestDigestRef==null || requestDigestRef.getDigestValue()==null || requestDigestRef.getDigestAlgorithm()==null) {
  691.                     erroriValidazione.add(this.validazioneUtils.newEccezioneValidazione(CodiceErroreCooperazione.PROFILO_TRASMISSIONE_NON_VALIDO, 
  692.                             "Header WSSecurity Signature; Header Request Digest non firmato"));
  693.                 }
  694.             }
  695.             
  696.             if(signAttachments) {
  697.                 
  698.                 List<String> cidAttachments = new ArrayList<>();
  699.                 try {
  700.                     if(msg.castAsSoap().hasAttachments()){
  701.                         Iterator<?> itAttach = msg.castAsSoap().getAttachments();
  702.                         while (itAttach.hasNext()) {
  703.                             AttachmentPart ap = (AttachmentPart) itAttach.next();
  704.                             String contentId = normalizeContentID(ap.getContentId());
  705.                             cidAttachments.add(contentId);
  706.                             /**System.out.println("ADD '"+contentId+"'");*/
  707.                         }
  708.                     }
  709.                 }catch(Exception e) {
  710.                     throw new ProtocolException(e.getMessage(),e);
  711.                 }
  712.                 
  713.                 if(attachmentsRef.isEmpty()) {
  714.                     if(requestDigestRef==null || requestDigestRef.getDigestValue()==null || requestDigestRef.getDigestAlgorithm()==null) {
  715.                         erroriValidazione.add(this.validazioneUtils.newEccezioneValidazione(CodiceErroreCooperazione.SICUREZZA_FIRMA_ALLEGATO_NON_PRESENTE, 
  716.                                 "Header WSSecurity Signature; Allegati non firmati"));
  717.                     }
  718.                 }
  719.                 else {
  720.                     for (WSDataRef wsDateRef : attachmentsRef) {
  721.                         
  722.                         String cid = null;
  723.                         String idLog = "";
  724.                         if(wsDateRef!=null) {
  725.                             cid = normalizeContentID(wsDateRef.getWsuId());
  726.                             idLog = (wsDateRef.getWsuId()!=null) ? " '"+cid+"'" : "";
  727.                         }
  728.                                                                         
  729.                         if(wsDateRef==null || wsDateRef.getDigestValue()==null || wsDateRef.getDigestAlgorithm()==null) {
  730.                             erroriValidazione.add(this.validazioneUtils.newEccezioneValidazione(CodiceErroreCooperazione.SICUREZZA_FIRMA_ALLEGATO_NON_VALIDA, 
  731.                                     "Header WSSecurity Signature; Allegato"+idLog+" non firmato (digest non presente)"));
  732.                         }
  733.                         if(cid==null) {
  734.                             erroriValidazione.add(this.validazioneUtils.newEccezioneValidazione(CodiceErroreCooperazione.SICUREZZA_FIRMA_ALLEGATO_NON_VALIDA, 
  735.                                     "Header WSSecurity Signature; Allegato"+idLog+" non firmato (cid non presente)"));
  736.                         }
  737.                         //System.out.println("CID FIRMATO '"+cid+"'");
  738.                         
  739.                         if(!cidAttachments.contains(cid)) {
  740.                             erroriValidazione.add(this.validazioneUtils.newEccezioneValidazione(CodiceErroreCooperazione.SICUREZZA_FIRMA_ALLEGATO_NON_VALIDA, 
  741.                                     "Header WSSecurity Signature; Allegato con id"+idLog+", riferito nella firma, non esiste"));
  742.                         }
  743.                         else {
  744.                             cidAttachments.remove(cid);
  745.                         }
  746.                     }
  747.                 }
  748.                 
  749.                 if(!cidAttachments.isEmpty()) {
  750.                     for (String cid : cidAttachments) {
  751.                         erroriValidazione.add(this.validazioneUtils.newEccezioneValidazione(CodiceErroreCooperazione.SICUREZZA_FIRMA_ALLEGATO_NON_VALIDA, 
  752.                                 "Header WSSecurity Signature; Allegato"+cid+" non firmato"));
  753.                     }
  754.                 }
  755.                 
  756.             }
  757.         }

  759.         
  760.         

  762.         /*
  763.          * == addressing ==
  764.          */
  765.         WSAddressingHeader wsAddressingHeader = null;
  766.         try {
  767.             WSAddressingUtilities wsaddressingUtilities = new WSAddressingUtilities(this.log);
  768.             wsAddressingHeader = wsaddressingUtilities.read(soapMessage, soapInfo.getHeader(), this.modiProperties.getSoapWSAddressingActor(), this.modiProperties.isSoapWSAddressingSchemaValidation());
  769.             if(wsAddressingHeader==null) {
  770.                 erroriValidazione.add(this.validazioneUtils.newEccezioneValidazione(CodiceErroreCooperazione.FORMATO_INTESTAZIONE_NON_PRESENTE, 
  771.                         "Header WSAddressing non presenti"));
  772.             }
  773.         }catch(Exception e) {
  774.             this.logError("Errore durante la letttura degli header WSAddressing: "+e.getMessage(),e);
  775.             erroriValidazione.add(this.validazioneUtils.newEccezioneValidazione(CodiceErroreCooperazione.FORMATO_INTESTAZIONE_NON_PRESENTE, 
  776.                     "Header WSAddressing; process failed: "+e.getMessage(),e));
  777.         }
  778.         
  779.         if(wsAddressingHeader!=null) {
  780.         
  781.             if(wsAddressingHeader.getTo()==null || wsAddressingHeader.getToValue()==null) {
  782.                 if(request || buildSecurityTokenInRequest) {
  783.                     erroriValidazione.add(this.validazioneUtils.newEccezioneValidazione(request ? CodiceErroreCooperazione.SERVIZIO_APPLICATIVO_EROGATORE_NON_PRESENTE :
  784.                         CodiceErroreCooperazione.SERVIZIO_APPLICATIVO_FRUITORE_NON_PRESENTE, 
  785.                             "Header WSAddressing '"+Costanti.WSA_SOAP_HEADER_TO+"' non presente"));
  786.                 }
  787.             }
  788.             else {
  789.                 busta.addProperty(ModICostanti.MODIPA_BUSTA_EXT_PROFILO_SICUREZZA_MESSAGGIO_SOAP_WSA_TO, wsAddressingHeader.getToValue());
  790.                 
  791.                 if(wsaToRef==null || wsaToRef.getDigestValue()==null || wsaToRef.getDigestAlgorithm()==null) {
  792.                     erroriValidazione.add(this.validazioneUtils.newEccezioneValidazione(request ? CodiceErroreCooperazione.SERVIZIO_APPLICATIVO_EROGATORE_NON_VALIDO :
  793.                         CodiceErroreCooperazione.SERVIZIO_APPLICATIVO_FRUITORE_NON_VALIDO, 
  794.                         "Header WSAddressing '"+Costanti.WSA_SOAP_HEADER_TO+"' non firmato"));
  795.                 }
  796.             }
  797.             
  798.             if(wsAddressingHeader.getFrom()!=null && wsAddressingHeader.getFromValue()!=null) {
  799.                 busta.addProperty(ModICostanti.MODIPA_BUSTA_EXT_PROFILO_SICUREZZA_MESSAGGIO_SOAP_WSA_FROM, wsAddressingHeader.getFromValue());
  800.             }
  801.             
  802.             if(wsAddressingHeader.getId()==null || wsAddressingHeader.getIdValue()==null) {
  803.                 if(filtroDuplicati) {
  804.                     erroriValidazione.add(this.validazioneUtils.newEccezioneValidazione(CodiceErroreCooperazione.IDENTIFICATIVO_MESSAGGIO_NON_PRESENTE,
  805.                         "Header WSAddressing '"+Costanti.WSA_SOAP_HEADER_ID+"' non presente"));
  806.                 }
  807.             }
  808.             else {
  809.                 String id = wsAddressingHeader.getIdValue();
  810.                 busta.addProperty(ModICostanti.MODIPA_BUSTA_EXT_PROFILO_SICUREZZA_MESSAGGIO_ID, id);
  811.                 if(id.length()<=255) {
  812.                     busta.setID(id);
  813.                 }
  814.                 
  815.                 if(filtroDuplicati) {
  816.                     if(wsaMessageIdRef==null || wsaMessageIdRef.getDigestValue()==null || wsaMessageIdRef.getDigestAlgorithm()==null) {
  817.                         erroriValidazione.add(this.validazioneUtils.newEccezioneValidazione(CodiceErroreCooperazione.IDENTIFICATIVO_MESSAGGIO_NON_VALIDO, 
  818.                                 "Header WSAddressing '"+Costanti.WSA_SOAP_HEADER_ID+"' non firmato"));
  819.                     }
  820.                 }
  821.             }
  822.             
  823.             if(wsAddressingHeader.getRelatesTo()!=null && wsAddressingHeader.getRelatesToValue()!=null) {
  824.                 String relatesTo =  wsAddressingHeader.getRelatesToValue();
  825.                 busta.addProperty(ModICostanti.MODIPA_BUSTA_EXT_PROFILO_SICUREZZA_MESSAGGIO_RELATES_TO, relatesTo);
  826.                 if(relatesTo.length()<=255) {
  827.                     busta.setRiferimentoMessaggio(relatesTo);
  828.                 }
  829.             }

  831.         }
  832.         if(wsAddressingHeader==null) {
  833.             return null;
  834.         }
  835.         
  836.         
  837.         /*
  838.          * == cornice sicurezza ==
  839.          */
  840.         if(corniceSicurezza) {
  841.             
  842.             DynamicNamespaceContext dnc = MessageDynamicNamespaceContextFactory.getInstance(msg.getFactory()).getNamespaceContext(securityHeader);
  843.             XPathExpressionEngine engine = new XPathExpressionEngine(msg.getFactory());
  844.             
  845.             String xpathSaml2CodiceEnte = new StringBuilder().append("//{").append(org.openspcoop2.message.constants.Costanti.SAML_20_NAMESPACE).
  846.                     append("}NameID/text()").toString();
  847.             try {
  848.                 String codiceEnte = engine.getStringMatchPattern(securityHeader, dnc, xpathSaml2CodiceEnte);
  849.                 if(codiceEnte==null || "".equals(codiceEnte)) {
  850.                     throw new XPathNotFoundException("non trovato");
  851.                 }
  852.                 busta.addProperty(ModICostanti.MODIPA_BUSTA_EXT_PROFILO_SICUREZZA_MESSAGGIO_CORNICE_SICUREZZA_CORNICE_SICUREZZA_ENTE, codiceEnte);
  853.             }
  854.             catch(XPathNotFoundException notFound) {
  855.                 erroriValidazione.add(this.validazioneUtils.newEccezioneValidazione(CodiceErroreCooperazione.MITTENTE_NON_PRESENTE, 
  856.                         ModICostanti.MODIPA_PROFILO_SICUREZZA_MESSAGGIO_CORNICE_SICUREZZA_LABEL+"; elemento 'Subject/NameID'"));
  857.             }catch(Exception e) {
  858.                 erroriValidazione.add(this.validazioneUtils.newEccezioneValidazione(CodiceErroreCooperazione.MITTENTE_NON_VALIDO, 
  859.                         ModICostanti.MODIPA_PROFILO_SICUREZZA_MESSAGGIO_CORNICE_SICUREZZA_LABEL+"; elemento 'Subject/NameID'"));
  860.             }
  861.             
  862.             String attributeNameUser = this.modiProperties.getSicurezzaMessaggioCorniceSicurezzaSoapUser();
  863.             String xpathSaml2User = new StringBuilder().append("//{").append(org.openspcoop2.message.constants.Costanti.SAML_20_NAMESPACE).
  864.                     append("}Attribute[@Name='").append(attributeNameUser).append("']//{").
  865.                     append(org.openspcoop2.message.constants.Costanti.SAML_20_NAMESPACE).append("}AttributeValue/text()").toString();
  866.             try {
  867.                 String user = engine.getStringMatchPattern(securityHeader, dnc, xpathSaml2User);
  868.                 if(user==null || "".equals(user)) {
  869.                     throw new XPathNotFoundException("non trovato");
  870.                 }
  871.                 busta.addProperty(ModICostanti.MODIPA_BUSTA_EXT_PROFILO_SICUREZZA_MESSAGGIO_CORNICE_SICUREZZA_CORNICE_SICUREZZA_USER, user);
  872.             }
  873.             catch(XPathNotFoundException notFound) {
  874.                 erroriValidazione.add(this.validazioneUtils.newEccezioneValidazione(CodiceErroreCooperazione.MITTENTE_NON_PRESENTE, 
  875.                         ModICostanti.MODIPA_PROFILO_SICUREZZA_MESSAGGIO_CORNICE_SICUREZZA_LABEL+"; elemento 'Attribute/"+attributeNameUser+"'"));
  876.             }catch(Exception e) {
  877.                 erroriValidazione.add(this.validazioneUtils.newEccezioneValidazione(CodiceErroreCooperazione.MITTENTE_NON_VALIDO, 
  878.                         ModICostanti.MODIPA_PROFILO_SICUREZZA_MESSAGGIO_CORNICE_SICUREZZA_LABEL+"; elemento 'Attribute/"+attributeNameUser+"'"));
  879.             }
  880.             
  881.             String attributeNameIpUser = this.modiProperties.getSicurezzaMessaggioCorniceSicurezzaSoapIpuser();
  882.             String xpathSaml2IpUser = new StringBuilder().append("//{").append(org.openspcoop2.message.constants.Costanti.SAML_20_NAMESPACE).
  883.                     append("}Attribute[@Name='").append(attributeNameIpUser).append("']//{").
  884.                     append(org.openspcoop2.message.constants.Costanti.SAML_20_NAMESPACE).append("}AttributeValue/text()").toString();
  885.             try {
  886.                 String ipUser = engine.getStringMatchPattern(securityHeader, dnc, xpathSaml2IpUser);
  887.                 if(ipUser==null || "".equals(ipUser)) {
  888.                     throw new XPathNotFoundException("non trovato");
  889.                 }
  890.                 busta.addProperty(ModICostanti.MODIPA_BUSTA_EXT_PROFILO_SICUREZZA_MESSAGGIO_CORNICE_SICUREZZA_CORNICE_SICUREZZA_USER_IP, ipUser);
  891.             }
  892.             catch(XPathNotFoundException notFound) {
  893.                 erroriValidazione.add(this.validazioneUtils.newEccezioneValidazione(CodiceErroreCooperazione.MITTENTE_NON_PRESENTE, 
  894.                         ModICostanti.MODIPA_PROFILO_SICUREZZA_MESSAGGIO_CORNICE_SICUREZZA_LABEL+"; elemento 'Attribute/"+attributeNameIpUser+"'"));
  895.             }catch(Exception e) {
  896.                 erroriValidazione.add(this.validazioneUtils.newEccezioneValidazione(CodiceErroreCooperazione.MITTENTE_NON_VALIDO, 
  897.                         ModICostanti.MODIPA_PROFILO_SICUREZZA_MESSAGGIO_CORNICE_SICUREZZA_LABEL+"; elemento 'Attribute/"+attributeNameIpUser+"'"));
  898.             }
  899.             
  900.         }
  901.         
  902.         
  903.         
  904.         /*
  905.          * == sbustamento/traccia ==
  906.          */
  907.         
  908.         ModISOAPSecurity soapSecurity = new ModISOAPSecurity();
  909.         
  910.         // elementi per costruire la traccia
  911.         soapSecurity.setSecurityHeader(securityHeader);
  912.         soapSecurity.setWsAddressingHeader(wsAddressingHeader);
  913.         soapSecurity.setRequestDigestHeader(requestDigestHeader);
  914.         if(bodyRef!=null) {
  915.             soapSecurity.setWsuIdBodyRef(bodyRef.getWsuId());
  916.         }
  917.         
  918.         // elementi per lo sbustamento
  919.         soapSecurity.setElementsToClean(elementsToClean);
  920.         soapSecurity.setMessageSecurityContext(messageSecurityContext);
  921.         soapSecurity.setWss4jSignature(wss4jSignature);
  922.         msg.addContextProperty(ModICostanti.MODIPA_OPENSPCOOP2_MSG_CONTEXT_SBUSTAMENTO_SOAP, soapSecurity);
  923.         
  924.         try {
  925.             SOAPEnvelope soapEnvelope = soapSecurity.buildTraccia(msg.getMessageType());
  926.             if(soapSecurityToken!=null) {
  927.                 soapSecurityToken.setToken(soapEnvelope);
  928.             }
  929.             return soapEnvelope;
  930.         }catch(Exception e) {
  931.             throw new ProtocolException(e.getMessage(),e);
  932.         }
  933.         
  934.     }
  935.     
  936.     private String normalizeContentID(String contentId) {
  937.         if(contentId==null) {
  938.             return null;
  939.         }
  940.         contentId = contentId.replace("&lt;", "<");
  941.         contentId = contentId.replace("&gt;", ">");
  942.         if(contentId.startsWith("cid:") && contentId.length()>4){
  943.             contentId = contentId.substring(4);
  944.         }
  945.         if(contentId.startsWith("<") && contentId.length()>1)
  946.             contentId = contentId.substring(1);
  947.         if(contentId.endsWith(">") && contentId.length()>1)
  948.             contentId = contentId.substring(0,contentId.length()-1);
  949.         return contentId;
  950.     }
  951.     
  952.     private void addValidationCorniceSicurezza(Map<String,Object> secProperties) {

  954.         secProperties.put(SAMLBuilderConfigConstants.SAML_CONFIG_BUILDER_VERSION, SAMLBuilderConfigConstants.SAML_CONFIG_BUILDER_VERSION_20);
  955.         secProperties.put(SecurityConstants.SAML_ENVELOPED_SAML_SIGNATURE_XMLCONFIG_PREFIX_ID, SecurityConstants.TRUE);
  956.         
  957.         if(ModIImbustamentoSoap.isSenderVouche()) {
  958.             secProperties.put("validateSamlSubjectConfirmation", SecurityConstants.TRUE);
  959.             secProperties.put(SecurityConstants.SAML_SUBJECT_CONFIRMATION_VALIDATION_METHOD_XMLCONFIG_ID, SecurityConstants.SAML_SUBJECT_CONFIRMATION_VALIDATION_METHOD_XMLCONFIG_ID_SENDER_VOUCHES);
  960.         }
  961.         else {
  962.             secProperties.put("validateSamlSubjectConfirmation", SecurityConstants.FALSE);
  963.         }

  965.     }
  966. }
Created with JaCoCo 0.8.8.202204050719