LocalForwardEngine.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.pdd.core;

  23. import java.util.ArrayList;
  24. import java.util.Iterator;
  25. import java.util.List;

  27. import javax.xml.transform.dom.DOMSource;

  29. import org.openspcoop2.core.config.PortaApplicativa;
  30. import org.openspcoop2.core.config.PortaDelegata;
  31. import org.openspcoop2.core.config.ServizioApplicativo;
  32. import org.openspcoop2.core.config.driver.DriverConfigurazioneNotFound;
  33. import org.openspcoop2.core.constants.TipoPdD;
  34. import org.openspcoop2.core.id.IDPortaApplicativa;
  35. import org.openspcoop2.core.id.IDServizio;
  36. import org.openspcoop2.core.id.IDServizioApplicativo;
  37. import org.openspcoop2.core.id.IDSoggetto;
  38. import org.openspcoop2.message.OpenSPCoop2Message;
  39. import org.openspcoop2.message.OpenSPCoop2MessageFactory;
  40. import org.openspcoop2.message.OpenSPCoop2SoapMessage;
  41. import org.openspcoop2.message.constants.MessageRole;
  42. import org.openspcoop2.message.exception.ParseException;
  43. import org.openspcoop2.message.utils.MessageUtilities;
  44. import org.openspcoop2.message.xml.MessageXMLUtils;
  45. import org.openspcoop2.pdd.config.MTOMProcessorConfig;
  46. import org.openspcoop2.pdd.config.MessageSecurityConfig;
  47. import org.openspcoop2.pdd.config.OpenSPCoop2Properties;
  48. import org.openspcoop2.pdd.config.RichiestaApplicativa;
  49. import org.openspcoop2.pdd.config.RichiestaDelegata;
  50. import org.openspcoop2.pdd.core.behaviour.Behaviour;
  51. import org.openspcoop2.pdd.core.dynamic.DynamicMapBuilderUtils;
  52. import org.openspcoop2.pdd.core.handlers.HandlerException;
  53. import org.openspcoop2.pdd.core.state.OpenSPCoopState;
  54. import org.openspcoop2.pdd.core.transazioni.Transaction;
  55. import org.openspcoop2.pdd.core.transazioni.TransactionContext;
  56. import org.openspcoop2.pdd.logger.MsgDiagnosticiProperties;
  57. import org.openspcoop2.pdd.mdb.Imbustamento;
  58. import org.openspcoop2.pdd.mdb.SbustamentoRisposte;
  59. import org.openspcoop2.pdd.services.ServicesUtils;
  60. import org.openspcoop2.pdd.services.error.AbstractErrorGenerator;
  61. import org.openspcoop2.pdd.services.error.RicezioneBusteExternalErrorGenerator;
  62. import org.openspcoop2.pdd.services.error.RicezioneContenutiApplicativiInternalErrorGenerator;
  63. import org.openspcoop2.protocol.engine.constants.Costanti;
  64. import org.openspcoop2.protocol.sdk.Busta;
  65. import org.openspcoop2.protocol.sdk.Eccezione;
  66. import org.openspcoop2.protocol.sdk.SecurityInfo;
  67. import org.openspcoop2.protocol.sdk.builder.ProprietaErroreApplicativo;
  68. import org.openspcoop2.protocol.sdk.constants.CodiceErroreCooperazione;
  69. import org.openspcoop2.protocol.sdk.constants.CodiceErroreIntegrazione;
  70. import org.openspcoop2.protocol.sdk.constants.ErroreIntegrazione;
  71. import org.openspcoop2.protocol.sdk.constants.ErroriCooperazione;
  72. import org.openspcoop2.protocol.sdk.constants.ErroriIntegrazione;
  73. import org.openspcoop2.protocol.sdk.constants.IntegrationFunctionError;
  74. import org.openspcoop2.protocol.sdk.constants.ProfiloDiCollaborazione;
  75. import org.openspcoop2.protocol.sdk.constants.RuoloMessaggio;
  76. import org.openspcoop2.protocol.sdk.state.IState;
  77. import org.openspcoop2.protocol.sdk.state.RequestInfo;
  78. import org.openspcoop2.protocol.sdk.validator.IValidazioneSemantica;
  79. import org.openspcoop2.security.message.MessageSecurityContext;
  80. import org.openspcoop2.security.message.MessageSecurityContextParameters;
  81. import org.openspcoop2.security.message.SubErrorCodeSecurity;
  82. import org.openspcoop2.security.message.constants.SecurityConstants;
  83. import org.openspcoop2.security.message.engine.MessageSecurityFactory;
  84. import org.openspcoop2.utils.Utilities;
  85. import org.openspcoop2.utils.date.DateManager;
  86. import org.openspcoop2.utils.date.DateUtils;
  87. import org.openspcoop2.utils.digest.IDigestReader;
  88. import org.openspcoop2.utils.transport.http.HttpConstants;
  89. import org.w3c.dom.Node;

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

  100.     private LocalForwardParameter localForwardParameter;
  101.     private EJBUtils ejbUtils = null;
  102.     private RicezioneContenutiApplicativiInternalErrorGenerator generatoreErrorePortaDelegata = null;
  103.     private RicezioneBusteExternalErrorGenerator generatoreErrorePortaApplicativa = null;
  104.     private Busta busta = null;
  105.     private IDPortaApplicativa idPA = null;
  106.     private PortaApplicativa pa = null;
  107.     private RichiestaApplicativa richiestaApplicativa = null;
  108.     private RichiestaDelegata richiestaDelegata = null;
  109.     private PortaDelegata pd =null;
  110.     private ServizioApplicativo sa = null;
  111.     private OpenSPCoop2Properties propertiesReader = null;
  112.     private RequestInfo requestInfo = null;
  113.     private IntegrationFunctionError _integrationFunctionError;
  114.     private IntegrationFunctionError getIntegrationFunctionError(PdDContext pddContext) {
  115.         if(this._integrationFunctionError!=null) {
  116.             return this._integrationFunctionError;
  117.         }
  118.         else {
  119.             return AbstractErrorGenerator.getIntegrationInternalError(pddContext); // default
  120.         }
  121.     }
  122.     
  123.     
  124.     /* ***** COSTRUTTORE ******** */
  125.     
  126.     public LocalForwardEngine(LocalForwardParameter localForwardParameter) throws LocalForwardException{
  127.         this.localForwardParameter = localForwardParameter;
  128.         try{
  129.             
  130.             this.propertiesReader = OpenSPCoop2Properties.getInstance();
  131.             
  132.             this.richiestaDelegata = this.localForwardParameter.getRichiestaDelegata();
  133.             this.richiestaApplicativa = this.localForwardParameter.getRichiestaApplicativa();
  134.             
  135.             ((OpenSPCoopState)this.localForwardParameter.getOpenspcoopstate()).setIDMessaggioSessione(this.localForwardParameter.getIdRequest());
  136.             IState state = ((OpenSPCoopState)this.localForwardParameter.getOpenspcoopstate()).getStatoRichiesta();
  137.             
  138.             String profiloGestione = null;
  139.             IDSoggetto soggettoFruitore = null;
  140.             IDServizio idServizio = null;
  141.             ProprietaErroreApplicativo fault = null;
  142.             String servizioApplicativo = null;
  143.             String scenarioCooperazione = null;
  144.             if(this.richiestaApplicativa!=null){
  145.                 profiloGestione = this.richiestaApplicativa.getProfiloGestione();
  146.                 soggettoFruitore = this.richiestaApplicativa.getSoggettoFruitore();
  147.                 idServizio = this.richiestaApplicativa.getIDServizio();
  148.                 fault = null;
  149.                 servizioApplicativo = this.richiestaApplicativa.getServizioApplicativo();
  150.                 scenarioCooperazione = this.richiestaApplicativa.getScenario();
  151.                 
  152.                 this.idPA = this.richiestaApplicativa.getIdPortaApplicativa();
  153.                 
  154.                 this.busta = this.localForwardParameter.getBusta();
  155.                                 
  156.             }else{
  157.                 profiloGestione = this.richiestaDelegata.getProfiloGestione();
  158.                 soggettoFruitore = this.richiestaDelegata.getIdSoggettoFruitore();
  159.                 idServizio = this.richiestaDelegata.getIdServizio();
  160.                 fault = this.richiestaDelegata.getFault();
  161.                 servizioApplicativo = this.richiestaDelegata.getServizioApplicativo();
  162.                 if(ProfiloDiCollaborazione.ONEWAY.equals(this.localForwardParameter.getInfoServizio().getProfiloDiCollaborazione())){
  163.                     scenarioCooperazione = Costanti.SCENARIO_ONEWAY_INVOCAZIONE_SERVIZIO;
  164.                 }
  165.                 else if(ProfiloDiCollaborazione.SINCRONO.equals(this.localForwardParameter.getInfoServizio().getProfiloDiCollaborazione())){
  166.                     scenarioCooperazione = Costanti.SCENARIO_SINCRONO_INVOCAZIONE_SERVIZIO;
  167.                 }
  168.                 
  169.                 this.idPA = this.localForwardParameter.getIdPortaApplicativaIndirizzata();
  170.                 
  171.                 this.richiestaApplicativa = 
  172.                         new RichiestaApplicativa(soggettoFruitore,  
  173.                                 this.localForwardParameter.getIdModulo(), this.localForwardParameter.getIdentitaPdD(),this.idPA);
  174.                 this.richiestaApplicativa.setIdCorrelazioneApplicativa(this.localForwardParameter.getIdCorrelazioneApplicativa());
  175.                 this.richiestaApplicativa.setProfiloGestione(profiloGestione);
  176.                 this.richiestaApplicativa.setRicevutaAsincrona(false);
  177.                 this.richiestaApplicativa.setLocalForward(true);
  178.                 this.richiestaApplicativa.setScenario(scenarioCooperazione);
  179.                 if(!CostantiPdD.SERVIZIO_APPLICATIVO_ANONIMO.equals(servizioApplicativo)){
  180.                     this.richiestaApplicativa.setIdentitaServizioApplicativoFruitore(servizioApplicativo);
  181.                 }
  182.                                 
  183.                 this.busta = new Busta(this.localForwardParameter.getProtocolFactory(), 
  184.                         this.localForwardParameter.getInfoServizio(), 
  185.                         soggettoFruitore,idServizio.getSoggettoErogatore(), 
  186.                         this.localForwardParameter.getIdRequest(), false);
  187.                 this.busta.setID(this.localForwardParameter.getIdRequest());
  188.             }
  189.             
  190.             this.pd = this.localForwardParameter.getConfigurazionePdDReader().getPortaDelegata(this.richiestaDelegata.getIdPortaDelegata(), this.requestInfo);  
  191.             try{
  192.                 IDServizioApplicativo idSA = new IDServizioApplicativo();
  193.                 idSA.setNome(this.richiestaDelegata.getServizioApplicativo());
  194.                 idSA.setIdSoggettoProprietario(this.richiestaDelegata.getIdSoggettoFruitore());
  195.                 this.sa = this.localForwardParameter.getConfigurazionePdDReader().getServizioApplicativo(idSA, this.requestInfo);
  196.             }catch(DriverConfigurazioneNotFound e){
  197.                 if(CostantiPdD.SERVIZIO_APPLICATIVO_ANONIMO.equals(this.richiestaDelegata.getServizioApplicativo())==false)
  198.                     throw e;
  199.             }
  200.             
  201.             this.requestInfo = (RequestInfo) this.localForwardParameter.getPddContext().getObject(org.openspcoop2.core.constants.Costanti.REQUEST_INFO);
  202.             
  203.             if(fault==null){
  204.                 fault = this.propertiesReader.getProprietaGestioneErrorePD(this.localForwardParameter.getProtocolFactory().createProtocolManager());
  205.                 fault.setDominio(this.localForwardParameter.getIdentitaPdD().getCodicePorta());
  206.                 fault.setIdModulo(this.localForwardParameter.getIdModulo());
  207.                 this.localForwardParameter.getConfigurazionePdDReader().aggiornaProprietaGestioneErrorePD(fault, this.sa);
  208.             }
  209.             
  210.             this.ejbUtils = new EJBUtils(this.localForwardParameter.getIdentitaPdD(), TipoPdD.DELEGATA, 
  211.                     this.localForwardParameter.getIdModulo(), this.localForwardParameter.getIdRequest(), this.localForwardParameter.getIdRequest(), Costanti.OUTBOX, 
  212.                     this.localForwardParameter.getOpenspcoopstate(), this.localForwardParameter.getMsgDiag(), false, 
  213.                     this.localForwardParameter.getImplementazionePdDMittente(), this.localForwardParameter.getImplementazionePdDDestinatario(), 
  214.                     profiloGestione, this.localForwardParameter.getPddContext());
  215.             this.ejbUtils.setOneWayVersione11(this.localForwardParameter.isOneWayVersione11());
  216.             this.ejbUtils.setPortaDiTipoStateless_esclusoOneWay11(this.localForwardParameter.isStateless() && !this.localForwardParameter.isOneWayVersione11());
  217.             
  218.             this.generatoreErrorePortaDelegata = new RicezioneContenutiApplicativiInternalErrorGenerator(this.localForwardParameter.getLog(), 
  219.                     this.localForwardParameter.getIdModulo(), this.requestInfo);
  220.             this.generatoreErrorePortaDelegata.updateInformazioniCooperazione(soggettoFruitore, idServizio);
  221.             this.generatoreErrorePortaDelegata.updateInformazioniCooperazione(servizioApplicativo);
  222.             this.generatoreErrorePortaDelegata.updateProprietaErroreApplicativo(fault);
  223.                 
  224.             this.generatoreErrorePortaApplicativa = new RicezioneBusteExternalErrorGenerator(this.localForwardParameter.getLog(), 
  225.                     this.localForwardParameter.getIdModulo(), this.requestInfo, state);
  226.             this.generatoreErrorePortaApplicativa.updateInformazioniCooperazione(soggettoFruitore, idServizio);
  227.             this.generatoreErrorePortaApplicativa.updateInformazioniCooperazione(servizioApplicativo);
  228.             
  229.             this.ejbUtils.setGeneratoreErrorePortaApplicativa(this.generatoreErrorePortaApplicativa);
  230.             
  231.             this.pa = this.localForwardParameter.getConfigurazionePdDReader().getPortaApplicativa(this.idPA, this.requestInfo);
  232.             
  233.             
  234.             
  235.         }catch(Exception e){
  236.             throw new LocalForwardException(e.getMessage(),e);
  237.         }
  238.     }
  239.     
  240.     public void updateLocalForwardParameter(LocalForwardParameter localForwardParameter) throws LocalForwardException{
  241.         this.localForwardParameter = localForwardParameter;
  242.     }
  243.     
  244.     public void setIntegrationFunctionError(IntegrationFunctionError integrationError) {
  245.         this._integrationFunctionError = integrationError;
  246.     }
  247.     
  248.     private Transaction getTransactionNullable() {
  249.         String idTransazione = (String) this.localForwardParameter.getPddContext().getObject(org.openspcoop2.core.constants.Costanti.ID_TRANSAZIONE);
  250.         Transaction transactionNullable = null;
  251.         try{
  252.             transactionNullable = TransactionContext.getTransaction(idTransazione);
  253.         }catch(Exception e){
  254.             // puo' non essere presente in comunicazioni stateful
  255.         }
  256.         return transactionNullable;
  257.     }
  258.     
  259.     
  260.     
  261.     
  262.     
  263.     
  264.     /* ***** PROCESS REQUEST ******** */
  265.     
  266.     private SecurityInfo securityInfoRequest = null;
  267.     public SecurityInfo getSecurityInfoRequest() {
  268.         return this.securityInfoRequest;
  269.     }
  270.     private OpenSPCoop2Message responseMessageError = null;
  271.     public OpenSPCoop2Message getResponseMessageError() {
  272.         return this.responseMessageError;
  273.     }
  274.     private OpenSPCoop2Message requestMessageAfterProcess = null;
  275.     public OpenSPCoop2Message getRequestMessageAfterProcess() {
  276.         return this.requestMessageAfterProcess;
  277.     }

  279.     private MessageSecurityConfig securityConfigPDRequest = null;
  280.     private MessageSecurityConfig securityConfigPARequest = null;
  281.     
  282.     public boolean processRequest(OpenSPCoop2Message requestMessage) throws LocalForwardException{
  283.         
  284.         try{

  286.             ErroreIntegrazione erroreIntegrazione = null;
  287.             CodiceErroreCooperazione codiceErroreCooperazione = null;
  288.             Exception configException = null;
  289.             MessageSecurityFactory messageSecurityFactory = new MessageSecurityFactory();
  290.         
  291.             IState state = ((OpenSPCoopState)this.localForwardParameter.getOpenspcoopstate()).getStatoRichiesta();
  292.             
  293.             PdDContext pddContext = this.localForwardParameter.getPddContext();
  294.             
  295.             
  296.             /* ****************** PORTA DELEGATA **************************** */
  297.             
  298.             
  299.             /* *** Init MTOM Processor / SecurityContext *** */
  300.             boolean messageSecurityApply = false;
  301.             this.localForwardParameter.getMsgDiag().mediumDebug("init MTOM Processor / SecurityContext (PD) ...");
  302.             MTOMProcessorConfig mtomConfig = null;
  303.             String msgErrore = null;
  304.             String posizione = null;
  305.             MTOMProcessor mtomProcessor = null;
  306.             boolean logDiagnosticError = true;
  307.             IntegrationFunctionError integrationFunctionError = null;
  308.             try{
  309.                 this.securityConfigPDRequest=this.localForwardParameter.getConfigurazionePdDReader().getMessageSecurityForSender(this.pd, this.localForwardParameter.getLog(), requestMessage, this.busta, this.requestInfo, this.localForwardParameter.getPddContext());
  310.             }catch(Exception e){
  311.                 posizione = "LetturaParametriSicurezzaMessaggioPDRequest";
  312.                 erroreIntegrazione = ErroriIntegrazione.ERRORE_5XX_GENERICO_PROCESSAMENTO_MESSAGGIO.
  313.                         get5XX_ErroreProcessamento(e,CodiceErroreIntegrazione.CODICE_536_CONFIGURAZIONE_NON_DISPONIBILE);
  314.                 configException = e;
  315.                 integrationFunctionError = IntegrationFunctionError.INTERNAL_REQUEST_ERROR;
  316.             }
  317.             if(erroreIntegrazione==null){
  318.                 try{
  319.                     mtomConfig=this.localForwardParameter.getConfigurazionePdDReader().getMTOMProcessorForSender(this.pd);
  320.                 }catch(Exception e){
  321.                     posizione = "LetturaParametriMTOMProcessorPDRequest";
  322.                     erroreIntegrazione = ErroriIntegrazione.ERRORE_5XX_GENERICO_PROCESSAMENTO_MESSAGGIO.
  323.                             get5XX_ErroreProcessamento(e,CodiceErroreIntegrazione.CODICE_536_CONFIGURAZIONE_NON_DISPONIBILE);
  324.                     configException = e;
  325.                     integrationFunctionError = IntegrationFunctionError.INTERNAL_REQUEST_ERROR;
  326.                 }
  327.             }       
  328.             if(erroreIntegrazione==null){
  329.                 mtomProcessor = new MTOMProcessor(mtomConfig, this.securityConfigPDRequest, TipoPdD.DELEGATA, 
  330.                         this.localForwardParameter.getMsgDiag(), this.localForwardParameter.getLog(), 
  331.                         this.localForwardParameter.getPddContext());
  332.             }
  333.                     
  334.             /* *** MTOM Processor BeforeSecurity  *** */
  335.             if(mtomProcessor!=null && erroreIntegrazione==null){
  336.                 try{
  337.                     mtomProcessor.mtomBeforeSecurity(requestMessage, RuoloMessaggio.RICHIESTA);
  338.                 }catch(Exception e){
  339.                     logDiagnosticError = false; // L'errore viene registrato dentro il metodo mtomProcessor.mtomBeforeSecurity
  340.                     
  341.                     posizione = "MTOMProcessor(BeforeSec-"+mtomProcessor.getMTOMProcessorType()+")PDRequest";
  342.                     erroreIntegrazione = ErroriIntegrazione.ERRORE_5XX_GENERICO_PROCESSAMENTO_MESSAGGIO.
  343.                             get5XX_ErroreProcessamento(e,CodiceErroreIntegrazione.CODICE_557_MTOM_PROCESSOR_ERROR);
  344.                     configException = e;
  345.                     integrationFunctionError = IntegrationFunctionError.ATTACHMENTS_PROCESSING_REQUEST_FAILED;
  346.                 }
  347.             }
  348.             
  349.             /* *** MessageSecurity *** */
  350.             MessageSecurityContext messageSecurityContext = null;
  351.             if(erroreIntegrazione==null){
  352.                 if(this.securityConfigPDRequest!=null && this.securityConfigPDRequest.getFlowParameters()!=null &&
  353.                         this.securityConfigPDRequest.getFlowParameters().size() > 0){
  354.                     try{
  355.                         this.localForwardParameter.getMsgDiag().mediumDebug("Inizializzazione contesto di Message Security (PD) della richiesta ...");
  356.                         messageSecurityApply = true;
  357.                         MessageSecurityContextParameters contextParameters = new MessageSecurityContextParameters();
  358.                         contextParameters.setUseActorDefaultIfNotDefined(this.propertiesReader.isGenerazioneActorDefault(this.localForwardParameter.getImplementazionePdDDestinatario()));
  359.                         contextParameters.setActorDefault(this.propertiesReader.getActorDefault(this.localForwardParameter.getImplementazionePdDDestinatario()));
  360.                         contextParameters.setLog(this.localForwardParameter.getLog());
  361.                         contextParameters.setFunctionAsClient(SecurityConstants.SECURITY_CLIENT);
  362.                         contextParameters.setPrefixWsuId(this.propertiesReader.getPrefixWsuId());
  363.                         contextParameters.setRemoveAllWsuIdRef(this.propertiesReader.isRemoveAllWsuIdRef());
  364.                         contextParameters.setIdFruitore(this.richiestaDelegata.getIdSoggettoFruitore());
  365.                         contextParameters.setIdServizio(this.richiestaDelegata.getIdServizio());
  366.                         contextParameters.setPddFruitore(this.localForwardParameter.getIdPdDMittente());
  367.                         contextParameters.setPddErogatore(this.localForwardParameter.getIdPdDDestinatario());
  368.                         messageSecurityContext = messageSecurityFactory.getMessageSecurityContext(contextParameters);
  369.                         messageSecurityContext.setOutgoingProperties(this.securityConfigPDRequest.getFlowParameters());
  370.                         
  371.                         this.localForwardParameter.getMsgDiag().mediumDebug("Inizializzazione contesto di Message Security (PD) della richiesta completata con successo");
  372.                         
  373.                         if(org.openspcoop2.security.message.engine.WSSUtilities.isNormalizeToSaajImpl(messageSecurityContext)){
  374.                             this.localForwardParameter.getMsgDiag().mediumDebug("Normalize to saajImpl");
  375.                             //System.out.println("InoltroBusteEgov.request.normalize");
  376.                             requestMessage = requestMessage.normalizeToSaajImpl();
  377.                             this.requestMessageAfterProcess = requestMessage; // per aggiornare il messaggio fuori dall'engine
  378.                         }
  379.                         
  380.                         String tipoSicurezza = SecurityConstants.convertActionToString(messageSecurityContext.getOutgoingProperties());
  381.                         this.localForwardParameter.getMsgDiag().addKeyword(CostantiPdD.KEY_TIPO_SICUREZZA_MESSAGGIO_RICHIESTA, tipoSicurezza);
  382.                         this.localForwardParameter.getMsgDiag().logPersonalizzato(MsgDiagnosticiProperties.MSG_DIAG_INOLTRO_BUSTE,"messageSecurity.processamentoRichiestaInCorso");                 
  383.                         DynamicMapBuilderUtils.injectDynamicMap(this.busta, this.requestInfo, pddContext, this.localForwardParameter.getLog());
  384.                         if(messageSecurityContext.processOutgoing(requestMessage,this.localForwardParameter.getPddContext(),
  385.                                 getTransactionNullable()!=null ? getTransactionNullable().getTempiElaborazione() : null) == false){
  386.                             msgErrore = messageSecurityContext.getMsgErrore();
  387.                             codiceErroreCooperazione = messageSecurityContext.getCodiceErrore();
  388.                             
  389.                             this.localForwardParameter.getMsgDiag().addKeyword(CostantiPdD.KEY_ERRORE_PROCESSAMENTO , "["+codiceErroreCooperazione+"] "+msgErrore );
  390.                             this.localForwardParameter.getMsgDiag().logPersonalizzato(MsgDiagnosticiProperties.MSG_DIAG_INOLTRO_BUSTE,"messageSecurity.processamentoRichiestaInErrore");
  391.                         }
  392.                         else{
  393.                             this.localForwardParameter.getMsgDiag().logPersonalizzato(MsgDiagnosticiProperties.MSG_DIAG_INOLTRO_BUSTE,"messageSecurity.processamentoRichiestaEffettuato");
  394.                         }
  395.                     }catch(Exception e){
  396.                         
  397.                         this.localForwardParameter.getMsgDiag().addKeywordErroreProcessamento(e);
  398.                         this.localForwardParameter.getMsgDiag().logPersonalizzato(MsgDiagnosticiProperties.MSG_DIAG_INOLTRO_BUSTE,"messageSecurity.processamentoRichiestaInErrore");
  399.                         this.localForwardParameter.getLog().error("[MessageSecurityRequest]" + e.getMessage(),e);
  400.                         
  401.                         posizione = "MessageSecurityPortaDelegataRequestFlow";
  402.                         erroreIntegrazione = ErroriIntegrazione.ERRORE_5XX_GENERICO_PROCESSAMENTO_MESSAGGIO.
  403.                                 get5XX_ErroreProcessamento(e,CodiceErroreIntegrazione.CODICE_536_CONFIGURAZIONE_NON_DISPONIBILE);
  404.                         configException = e;
  405.                         integrationFunctionError = IntegrationFunctionError.MESSAGE_SECURITY_REQUEST_FAILED;
  406.                     }
  407.                 }
  408.                 else{
  409.                     this.localForwardParameter.getMsgDiag().logPersonalizzato(MsgDiagnosticiProperties.MSG_DIAG_INOLTRO_BUSTE,"messageSecurity.processamentoRichiestaDisabilitato");
  410.                 }
  411.             }
  412.             
  413.             /* *** ReadSecurityInformation *** */
  414.             if(erroreIntegrazione==null && codiceErroreCooperazione==null){
  415.                 IDigestReader digestReader = null;
  416.                 if(messageSecurityContext != null) {
  417.                     digestReader = messageSecurityContext.getDigestReader(requestMessage!=null ? requestMessage.getFactory() : OpenSPCoop2MessageFactory.getDefaultMessageFactory());
  418.                 }
  419.                 if(digestReader!=null){
  420.                     try{
  421.                         this.localForwardParameter.getMsgDiag().mediumDebug("ReadSecurityInformation (PD) ...");
  422.                         IValidazioneSemantica validazioneSemantica = this.localForwardParameter.getProtocolFactory().createValidazioneSemantica(state);
  423.                         this.securityInfoRequest = validazioneSemantica.readSecurityInformation(digestReader,requestMessage);
  424.                     }catch(Exception e){
  425.                         posizione = "LetturaInformazioniSicurezzaPDRequest";
  426.                         erroreIntegrazione = ErroriIntegrazione.ERRORE_5XX_GENERICO_PROCESSAMENTO_MESSAGGIO.
  427.                             get5XX_ErroreProcessamento(CodiceErroreIntegrazione.CODICE_549_SECURITY_INFO_READER_ERROR);
  428.                         configException = e;
  429.                         integrationFunctionError = IntegrationFunctionError.MESSAGE_SECURITY_REQUEST_FAILED;
  430.                     }
  431.                 }
  432.             }
  433.             
  434.             /* *** MTOM Processor AfterSecurity  *** */
  435.             if(mtomProcessor!=null && erroreIntegrazione==null){
  436.                 try{
  437.                     mtomProcessor.mtomAfterSecurity(requestMessage, RuoloMessaggio.RICHIESTA);
  438.                 }catch(Exception e){
  439.                     logDiagnosticError = false; // L'errore viene registrato dentro il metodo mtomProcessor.mtomAfterSecurity
  440.                     
  441.                     posizione = "MTOMProcessor(AfterSec-"+mtomProcessor.getMTOMProcessorType()+")PDRequest";
  442.                     erroreIntegrazione = ErroriIntegrazione.ERRORE_5XX_GENERICO_PROCESSAMENTO_MESSAGGIO.
  443.                             get5XX_ErroreProcessamento(e,CodiceErroreIntegrazione.CODICE_557_MTOM_PROCESSOR_ERROR);
  444.                     configException = e;
  445.                     integrationFunctionError = IntegrationFunctionError.ATTACHMENTS_PROCESSING_REQUEST_FAILED;
  446.                 }
  447.             }
  448.             
  449.             /* *** Gestione eventuale errore  *** */
  450.             if(erroreIntegrazione!=null || codiceErroreCooperazione!= null){
  451.                 if(integrationFunctionError==null) {
  452.                     integrationFunctionError = IntegrationFunctionError.INTERNAL_REQUEST_ERROR;
  453.                 }
  454.                 if(erroreIntegrazione!=null){
  455.                     if(logDiagnosticError){
  456.                         this.localForwardParameter.getMsgDiag().logErroreGenerico(erroreIntegrazione.getDescrizione(this.localForwardParameter.getProtocolFactory()), 
  457.                                 posizione);
  458.                     }
  459.                     this.responseMessageError = this.generatoreErrorePortaDelegata.build(pddContext, integrationFunctionError,
  460.                             erroreIntegrazione,configException,null);
  461.                 }else{
  462.                     Eccezione ecc = Eccezione.getEccezioneValidazione(ErroriCooperazione.MESSAGE_SECURITY.getErroreMessageSecurity(msgErrore, codiceErroreCooperazione),
  463.                             this.localForwardParameter.getProtocolFactory());
  464.                     if(logDiagnosticError){
  465.                         this.localForwardParameter.getMsgDiag().logErroreGenerico(ecc.getDescrizione(this.localForwardParameter.getProtocolFactory()), 
  466.                                 posizione);
  467.                     }
  468.                     this.responseMessageError = this.generatoreErrorePortaDelegata.build(pddContext, integrationFunctionError,
  469.                             ecc,this.richiestaDelegata.getIdSoggettoFruitore(),null);
  470.                 }
  471.                 if(logDiagnosticError==false){
  472.                     // comunque effettuo log nel core. Puo' darsi in alcuni casi che non venga registrato (es. NullPointer)
  473.                     this.localForwardParameter.getLog().error("("+posizione+") "+Utilities.readFirstErrorValidMessageFromException(configException),configException);
  474.                 }

  476.             }
  477.             if(this.responseMessageError!=null){
  478.                 return false;
  479.             }

  481.             
  482.             
  483.             
  484.             
  485.             
  486.             
  487.             
  488.             
  489.             /* ****************** PORTA APPLICATIVA **************************** */
  490.             
  491.             /* *** Init MTOM Processor / SecurityContext *** */
  492.             this.localForwardParameter.getMsgDiag().mediumDebug("init MTOM Processor / SecurityContext (PA) ...");
  493.             erroreIntegrazione = null;
  494.             codiceErroreCooperazione = null;
  495.             configException = null;
  496.             mtomConfig = null;
  497.             mtomProcessor = null;
  498.             msgErrore = null;
  499.             posizione = null;
  500.             messageSecurityContext = null;
  501.             logDiagnosticError = true;
  502.             integrationFunctionError = null;
  503.             try{
  504.                 this.securityConfigPARequest=this.localForwardParameter.getConfigurazionePdDReader().getMessageSecurityForReceiver(this.pa, this.localForwardParameter.getLog(), requestMessage, this.busta, this.requestInfo, this.localForwardParameter.getPddContext());
  505.             }catch(Exception e){
  506.                 posizione = "LetturaParametriSicurezzaMessaggioPARequest";
  507.                 erroreIntegrazione = ErroriIntegrazione.ERRORE_5XX_GENERICO_PROCESSAMENTO_MESSAGGIO.
  508.                         get5XX_ErroreProcessamento(e,CodiceErroreIntegrazione.CODICE_536_CONFIGURAZIONE_NON_DISPONIBILE);
  509.                 configException = e;
  510.                 integrationFunctionError = IntegrationFunctionError.INTERNAL_REQUEST_ERROR;
  511.             }
  512.             if(erroreIntegrazione==null){
  513.                 try{
  514.                     mtomConfig=this.localForwardParameter.getConfigurazionePdDReader().getMTOMProcessorForReceiver(this.pa);
  515.                 }catch(Exception e){
  516.                     posizione = "LetturaParametriMTOMProcessorPARequest";
  517.                     erroreIntegrazione = ErroriIntegrazione.ERRORE_5XX_GENERICO_PROCESSAMENTO_MESSAGGIO.
  518.                             get5XX_ErroreProcessamento(e,CodiceErroreIntegrazione.CODICE_536_CONFIGURAZIONE_NON_DISPONIBILE);
  519.                     configException = e;
  520.                     integrationFunctionError = IntegrationFunctionError.INTERNAL_REQUEST_ERROR;
  521.                 }
  522.             }       
  523.             if(erroreIntegrazione==null){
  524.                 mtomProcessor = new MTOMProcessor(mtomConfig, this.securityConfigPARequest, TipoPdD.APPLICATIVA, 
  525.                         this.localForwardParameter.getMsgDiag(), this.localForwardParameter.getLog(),
  526.                         this.localForwardParameter.getPddContext());
  527.             }
  528.             
  529.             /* *** MTOM Processor BeforeSecurity  *** */
  530.             if(mtomProcessor!=null && erroreIntegrazione==null){
  531.                 try{
  532.                     mtomProcessor.mtomBeforeSecurity(requestMessage, RuoloMessaggio.RICHIESTA);
  533.                 }catch(Exception e){
  534.                     logDiagnosticError = false; // L'errore viene registrato dentro il metodo mtomProcessor.mtomBeforeSecurity
  535.                     
  536.                     posizione = "MTOMProcessor(BeforeSec-"+mtomProcessor.getMTOMProcessorType()+")PARequest";
  537.                     erroreIntegrazione = ErroriIntegrazione.ERRORE_5XX_GENERICO_PROCESSAMENTO_MESSAGGIO.
  538.                             get5XX_ErroreProcessamento(e,CodiceErroreIntegrazione.CODICE_557_MTOM_PROCESSOR_ERROR);
  539.                     configException = e;
  540.                     integrationFunctionError = IntegrationFunctionError.ATTACHMENTS_PROCESSING_REQUEST_FAILED;
  541.                 }
  542.             }
  543.             
  544.             /* *** MessageSecurity (InitContext) *** */
  545.             if(erroreIntegrazione==null && this.securityConfigPARequest!=null && this.securityConfigPARequest.getFlowParameters()!=null){
  546.                 if(this.securityConfigPARequest.getFlowParameters().size() > 0){
  547.                     try{
  548.                         this.localForwardParameter.getMsgDiag().mediumDebug("Inizializzazione contesto di Message Security (PA) della richiesta ...");
  549.                         
  550.                         if(messageSecurityApply){
  551.                             
  552.                             OpenSPCoop2SoapMessage soapMessage = requestMessage.castAsSoap();
  553.                             
  554.                             // Per poter applicare anche questa config devo rigenerare tutto il messaggio
  555. //                          requestMessage.writeTo(System.out, false);
  556.                             DOMSource s = (DOMSource) soapMessage.getSOAPPart().getContent();
  557.                             Node n = s.getNode();
  558.                             MessageXMLUtils xmlUtils = MessageXMLUtils.getInstance(requestMessage.getFactory());
  559.                             byte[] bytes = xmlUtils.toByteArray(n);
  560. //                          System.out.println("A:"+new String(bytes));
  561.                             soapMessage.getSOAPPart().setContent(new DOMSource(xmlUtils.newElement(bytes)));
  562. //                          System.out.println("B");
  563. //                          requestMessage.writeTo(System.out, false);
  564.                         }
  565.     
  566.                         MessageSecurityContextParameters contextParameters = new MessageSecurityContextParameters();
  567.                         contextParameters.setUseActorDefaultIfNotDefined(this.propertiesReader.isGenerazioneActorDefault(this.localForwardParameter.getImplementazionePdDMittente()));
  568.                         contextParameters.setActorDefault(this.propertiesReader.getActorDefault(this.localForwardParameter.getImplementazionePdDMittente()));
  569.                         contextParameters.setLog(this.localForwardParameter.getLog());
  570.                         contextParameters.setFunctionAsClient(SecurityConstants.SECURITY_SERVER);
  571.                         contextParameters.setPrefixWsuId(this.propertiesReader.getPrefixWsuId());
  572.                         contextParameters.setRemoveAllWsuIdRef(this.propertiesReader.isRemoveAllWsuIdRef());
  573.                         contextParameters.setIdFruitore(this.richiestaDelegata.getIdSoggettoFruitore());
  574.                         contextParameters.setIdServizio(this.richiestaDelegata.getIdServizio());
  575.                         contextParameters.setPddFruitore(this.localForwardParameter.getIdPdDMittente());
  576.                         contextParameters.setPddErogatore(this.localForwardParameter.getIdPdDDestinatario());
  577.                         messageSecurityContext = messageSecurityFactory.getMessageSecurityContext(contextParameters);
  578.                         messageSecurityContext.setIncomingProperties(this.securityConfigPARequest.getFlowParameters());
  579.                         
  580.                         this.localForwardParameter.getMsgDiag().mediumDebug("Inizializzazione contesto di Message Security (PA) della richiesta completata con successo");
  581.                         
  582.                     }catch(Exception e){
  583.                         posizione = "MessageSecurityPortaApplicativaRequestFlowInitContext";
  584.                         erroreIntegrazione = ErroriIntegrazione.ERRORE_5XX_GENERICO_PROCESSAMENTO_MESSAGGIO.
  585.                                 get5XX_ErroreProcessamento(e,CodiceErroreIntegrazione.CODICE_536_CONFIGURAZIONE_NON_DISPONIBILE);
  586.                         configException = e;
  587.                         integrationFunctionError = IntegrationFunctionError.INTERNAL_REQUEST_ERROR;
  588.                     }
  589.                 }
  590.             }
  591.             
  592.             /* *** ReadSecurityInformation *** */
  593.             if(erroreIntegrazione==null && messageSecurityContext!=null){
  594.                 IDigestReader digestReader = null;
  595.                 if(messageSecurityContext != null) {
  596.                     digestReader = messageSecurityContext.getDigestReader(requestMessage!=null ? requestMessage.getFactory() : OpenSPCoop2MessageFactory.getDefaultMessageFactory());
  597.                 }
  598.                 if(digestReader!=null) {
  599.                     try{
  600.                         this.localForwardParameter.getMsgDiag().mediumDebug("ReadSecurityInformation (PA) ...");
  601.                         IValidazioneSemantica validazioneSemantica = this.localForwardParameter.getProtocolFactory().createValidazioneSemantica(state);
  602.                         this.securityInfoRequest = validazioneSemantica.readSecurityInformation(digestReader,requestMessage);
  603.                     }catch(Exception e){
  604.                         posizione = "LetturaInformazioniSicurezzaPARequest";
  605.                         erroreIntegrazione = ErroriIntegrazione.ERRORE_5XX_GENERICO_PROCESSAMENTO_MESSAGGIO.
  606.                             get5XX_ErroreProcessamento(CodiceErroreIntegrazione.CODICE_549_SECURITY_INFO_READER_ERROR);
  607.                         configException = e;
  608.                         integrationFunctionError = IntegrationFunctionError.MESSAGE_SECURITY_REQUEST_FAILED;
  609.                     }
  610.                 }
  611.             }
  612.             
  613.             /* *** MessageSecurity *** */
  614.             List<Eccezione> eccezioniSicurezza = new ArrayList<>();
  615.             if(erroreIntegrazione==null && messageSecurityContext!=null){
  616.                 try{
  617.                     if(org.openspcoop2.security.message.engine.WSSUtilities.isNormalizeToSaajImpl(messageSecurityContext)){
  618.                         this.localForwardParameter.getMsgDiag().mediumDebug("Normalize to saajImpl");
  619.                         //System.out.println("RicezioneBuste.request.normalize");
  620.                         requestMessage = requestMessage.normalizeToSaajImpl();
  621.                         this.requestMessageAfterProcess = requestMessage; // per aggiornare il messaggio fuori dall'engine
  622.                     }
  623.                     
  624.                     String tipoSicurezza = SecurityConstants.convertActionToString(messageSecurityContext.getIncomingProperties());
  625.                     this.localForwardParameter.getMsgDiag().addKeyword(CostantiPdD.KEY_TIPO_SICUREZZA_MESSAGGIO_RICHIESTA, tipoSicurezza);
  626.                     this.localForwardParameter.getMsgDiag().logPersonalizzato(MsgDiagnosticiProperties.MSG_DIAG_RICEZIONE_BUSTE,"messageSecurity.processamentoRichiestaInCorso");                   
  627.                     DynamicMapBuilderUtils.injectDynamicMap(this.busta, this.requestInfo, this.localForwardParameter.getPddContext(), this.localForwardParameter.getLog());
  628.                     if(messageSecurityContext.processIncoming(requestMessage,this.busta,this.localForwardParameter.getPddContext(),
  629.                             getTransactionNullable()!=null ? getTransactionNullable().getTempiElaborazione() : null) == false){  
  630.                         if(messageSecurityContext.getListaSubCodiceErrore()!=null && messageSecurityContext.getListaSubCodiceErrore().size()>0){
  631.                             List<SubErrorCodeSecurity> subCodiciErrore = messageSecurityContext.getListaSubCodiceErrore();
  632.                             for (Iterator<?> iterator = subCodiciErrore.iterator(); iterator.hasNext();) {
  633.                                 SubErrorCodeSecurity subCodiceErrore = (SubErrorCodeSecurity) iterator.next();
  634.                                 Eccezione ecc = new Eccezione(ErroriCooperazione.MESSAGE_SECURITY.getErroreMessageSecurity(subCodiceErrore.getMsgErrore(), messageSecurityContext.getCodiceErrore()),true,null, 
  635.                                         this.localForwardParameter.getProtocolFactory());
  636.                                 ecc.setSubCodiceEccezione(subCodiceErrore);
  637.                                 eccezioniSicurezza.add(ecc);
  638.                             }
  639.                         }else{
  640.                             Eccezione ecc = new Eccezione(ErroriCooperazione.MESSAGE_SECURITY.getErroreMessageSecurity(messageSecurityContext.getMsgErrore(),messageSecurityContext.getCodiceErrore()), true, null, 
  641.                                     this.localForwardParameter.getProtocolFactory());
  642.                             eccezioniSicurezza.add(ecc);
  643.                         }
  644.                         Eccezione ecc = eccezioniSicurezza.get(0); // prendo la prima disponibile.
  645.                         this.localForwardParameter.getMsgDiag().addKeyword(CostantiPdD.KEY_ERRORE_PROCESSAMENTO , "["+ecc.getCodiceEccezione()+"] "+ecc.getDescrizione(this.localForwardParameter.getProtocolFactory() ));
  646.                         this.localForwardParameter.getMsgDiag().logPersonalizzato(MsgDiagnosticiProperties.MSG_DIAG_RICEZIONE_BUSTE,"messageSecurity.processamentoRichiestaInErrore");
  647.                     }
  648.                     else{
  649.                         this.localForwardParameter.getMsgDiag().logPersonalizzato(MsgDiagnosticiProperties.MSG_DIAG_RICEZIONE_BUSTE,"messageSecurity.processamentoRichiestaEffettuato");
  650.                     }                                       
  651.                 }catch(Exception e){
  652.                     
  653.                     this.localForwardParameter.getMsgDiag().addKeywordErroreProcessamento(e);
  654.     
  655.                     this.localForwardParameter.getMsgDiag().logPersonalizzato(MsgDiagnosticiProperties.MSG_DIAG_RICEZIONE_BUSTE,"messageSecurity.processamentoRichiestaInErrore");
  656.                     
  657.                     posizione = "MessageSecurityPortaApplicativaRequestFlow";
  658.                     erroreIntegrazione = ErroriIntegrazione.ERRORE_5XX_GENERICO_PROCESSAMENTO_MESSAGGIO.
  659.                             get5XX_ErroreProcessamento(e,CodiceErroreIntegrazione.CODICE_536_CONFIGURAZIONE_NON_DISPONIBILE);
  660.                     configException = e;
  661.                     integrationFunctionError = IntegrationFunctionError.MESSAGE_SECURITY_REQUEST_FAILED;
  662.                 }
  663.             }
  664.             else{
  665.                 if(erroreIntegrazione==null){
  666.                     this.localForwardParameter.getMsgDiag().logPersonalizzato(MsgDiagnosticiProperties.MSG_DIAG_RICEZIONE_BUSTE,"messageSecurity.processamentoRichiestaDisabilitato");
  667.                 }
  668.             }
  669.             
  670.             /* *** MTOM Processor AfterSecurity  *** */
  671.             if(mtomProcessor!=null && erroreIntegrazione==null){
  672.                 try{
  673.                     mtomProcessor.mtomAfterSecurity(requestMessage, RuoloMessaggio.RICHIESTA);
  674.                 }catch(Exception e){
  675.                     logDiagnosticError = false; // L'errore viene registrato dentro il metodo mtomProcessor.mtomAfterSecurity
  676.                     
  677.                     posizione = "MTOMProcessor(AfterSec-"+mtomProcessor.getMTOMProcessorType()+")PARequest";
  678.                     erroreIntegrazione = ErroriIntegrazione.ERRORE_5XX_GENERICO_PROCESSAMENTO_MESSAGGIO.
  679.                             get5XX_ErroreProcessamento(e,CodiceErroreIntegrazione.CODICE_557_MTOM_PROCESSOR_ERROR);
  680.                     configException = e;
  681.                     integrationFunctionError = IntegrationFunctionError.ATTACHMENTS_PROCESSING_REQUEST_FAILED;
  682.                 }
  683.             }
  684.             
  685.             /* *** Gestione eventuale errore  *** */
  686.             if(erroreIntegrazione!=null || eccezioniSicurezza.size()>0){
  687.                 if(integrationFunctionError==null) {
  688.                     integrationFunctionError = IntegrationFunctionError.INTERNAL_REQUEST_ERROR;
  689.                 }
  690.                 if(erroreIntegrazione!=null){
  691.                     if(logDiagnosticError){
  692.                         this.localForwardParameter.getMsgDiag().logErroreGenerico(erroreIntegrazione.getDescrizione(this.localForwardParameter.getProtocolFactory()), 
  693.                                 posizione);
  694.                     }
  695.                     this.responseMessageError = this.generatoreErrorePortaDelegata.build(pddContext, integrationFunctionError,
  696.                             erroreIntegrazione,configException,null);
  697.                 }else{
  698.                     Eccezione ecc = eccezioniSicurezza.get(0); // prendo la prima disponibile.
  699.                     if(logDiagnosticError){
  700.                         this.localForwardParameter.getMsgDiag().logErroreGenerico(ecc.getDescrizione(this.localForwardParameter.getProtocolFactory()), 
  701.                                 posizione);
  702.                     }
  703.                     this.responseMessageError = this.generatoreErrorePortaDelegata.build(pddContext, integrationFunctionError,
  704.                             ecc,this.richiestaDelegata.getIdSoggettoFruitore(),null);
  705.                 }
  706.                 if(logDiagnosticError==false){
  707.                     // comunque effettuo log nel core. Puo' darsi in alcuni casi che non venga registrato (es. NullPointer)
  708.                     this.localForwardParameter.getLog().error("("+posizione+") "+Utilities.readFirstErrorValidMessageFromException(configException),configException);
  709.                 }
  710.             }
  711.             if(this.responseMessageError!=null){
  712.                 return false;
  713.             }

  715.             
  716.             
  717.             
  718.             
  719.             return true;
  720.             
  721.         }catch(Exception e){
  722.             throw new LocalForwardException(e.getMessage(),e);
  723.         }
  724.     }
  725.     
  726.     
  727.     
  728.     
  729.     
  730.     /* ***** SEND REQUEST ******** */
  731.     public void sendRequest(GestoreMessaggi gestoreMessaggiRequest) throws LocalForwardException{
  732.         
  733.         try{

  735.             Behaviour behaviour = this.ejbUtils.sendToConsegnaContenutiApplicativi(this.requestInfo, this.richiestaApplicativa, this.busta, gestoreMessaggiRequest, this.pa, 
  736.                     this.localForwardParameter.getRepositoryBuste(), this.richiestaDelegata);
  737.             boolean behaviourResponseTo = behaviour!=null && behaviour.isResponseTo();
  738.             
  739.             GestoreMessaggi msgOK = null;
  740.             
  741.             if(behaviourResponseTo){
  742.             
  743.                 this.localForwardParameter.getPddContext().addObject(org.openspcoop2.core.constants.Costanti.DATA_PRESA_IN_CARICO, 
  744.                         DateUtils.getSimpleDateFormatMs().format(DateManager.getDate()));
  745.                 
  746.                 this.localForwardParameter.getMsgDiag().mediumDebug("Invio messaggio 'OK' al modulo di RicezioneContenutiApplicativi (Behaviour)...");  
  747.                 
  748.                 OpenSPCoop2Message responseToMessage = null;
  749.                 if(behaviour.getResponseTo()!=null){
  750.                     responseToMessage = behaviour.getResponseTo().getMessage();
  751.                 }
  752.                 if(responseToMessage==null){
  753.                     if(this.localForwardParameter.getProtocolFactory().createProtocolManager().isHttpEmptyResponseOneWay()){
  754.                         responseToMessage =  MessageUtilities.buildEmptyMessage(OpenSPCoop2MessageFactory.getDefaultMessageFactory(), this.requestInfo.getIntegrationRequestMessageType(),MessageRole.RESPONSE);
  755.                     }
  756.                     else{
  757.                         responseToMessage = this.ejbUtils.buildOpenSPCoopOK(this.requestInfo.getIntegrationRequestMessageType(), this.localForwardParameter.getIdRequest());
  758.                     }
  759.                 }
  760.                 msgOK = this.ejbUtils.sendRispostaApplicativaOK(responseToMessage,
  761.                         this.richiestaDelegata,this.pd,this.sa);            
  762.                 
  763.             }else if(this.localForwardParameter.isStateless()==false || this.localForwardParameter.isOneWayVersione11() || this.ejbUtils.isGestioneSolamenteConIntegrationManager()){
  764.                 
  765.                 this.localForwardParameter.getPddContext().addObject(org.openspcoop2.core.constants.Costanti.DATA_PRESA_IN_CARICO, 
  766.                         DateUtils.getSimpleDateFormatMs().format(DateManager.getDate()));
  767.                 
  768.                 this.localForwardParameter.getMsgDiag().mediumDebug("Invio messaggio 'OK' al modulo di RicezioneContenutiApplicativi...");  
  769.                 
  770.                 if(this.localForwardParameter.getProtocolFactory().createProtocolManager().isHttpEmptyResponseOneWay())
  771.                     msgOK = this.ejbUtils.sendRispostaApplicativaOK(MessageUtilities.buildEmptyMessage(OpenSPCoop2MessageFactory.getDefaultMessageFactory(), this.requestInfo.getIntegrationRequestMessageType(),MessageRole.RESPONSE),this.richiestaDelegata,this.pd,this.sa);
  772.                 else
  773.                     msgOK = this.ejbUtils.sendRispostaApplicativaOK(this.ejbUtils.buildOpenSPCoopOK(this.requestInfo.getIntegrationRequestMessageType(), this.localForwardParameter.getIdRequest()),
  774.                             this.richiestaDelegata,this.pd,this.sa);
  775.             }
  776.             
  777.             
  778.             if(msgOK!=null)
  779.                 msgOK.addMessaggiIntoCache_readFromTable(Imbustamento.ID_MODULO, "messaggio OK");
  780.             
  781.             if(msgOK!=null)
  782.                 msgOK.addProprietariIntoCache_readFromTable(Imbustamento.ID_MODULO, "messaggio OK",this.localForwardParameter.getIdRequest(),false);
  783.             
  784.             
  785.         }catch(Exception e){
  786.             throw new LocalForwardException(e.getMessage(),e);
  787.         }
  788.         
  789.     }
  790.     
  791.     
  792.     
  793.     
  794.     
  795.     /* ***** PROCESS RESPONSE ******** */
  796.     private SecurityInfo securityInfoResponse = null;
  797.     public SecurityInfo getSecurityInfoResponse() {
  798.         return this.securityInfoResponse;
  799.     }
  800.     private OpenSPCoop2Message responseMessageAfterProcess = null;
  801.     public OpenSPCoop2Message getResponseMessageAfterProcess() {
  802.         return this.responseMessageAfterProcess;
  803.     }
  804.     public boolean processResponse(OpenSPCoop2Message responseMessage) throws LocalForwardException{
  805.         
  806.         try{
  807.             
  808.             ErroreIntegrazione erroreIntegrazione = null;
  809.             CodiceErroreCooperazione codiceErroreCooperazione = null;
  810.             Exception configException = null;
  811.             MessageSecurityFactory messageSecurityFactory = new MessageSecurityFactory();

  813.             IState state = ((OpenSPCoopState)this.localForwardParameter.getOpenspcoopstate()).getStatoRisposta();
  814.             
  815.             PdDContext pddContext = this.localForwardParameter.getPddContext();
  816.             
  817.             
  818.             
  819.             
  820.             /* ****************** PORTA APPLICATIVA **************************** */
  821.             
  822.             /* *** Init MTOM Processor / SecurityContext *** */
  823.             boolean messageSecurityApply = false;
  824.             this.localForwardParameter.getMsgDiag().mediumDebug("init MTOM Processor / SecurityContext (PA-Response) ...");
  825.             MessageSecurityConfig securityConfig = null;
  826.             MTOMProcessorConfig mtomConfig = null;
  827.             String msgErrore = null;
  828.             String posizione = null;
  829.             MTOMProcessor mtomProcessor = null;
  830.             boolean logDiagnosticError = true;
  831.             IntegrationFunctionError integrationFunctionError = null;
  832.             try{
  833.                 securityConfig=this.localForwardParameter.getConfigurazionePdDReader().getMessageSecurityForSender(this.pa, this.localForwardParameter.getLog(), responseMessage, this.busta, this.requestInfo, this.localForwardParameter.getPddContext(),
  834.                         this.securityConfigPARequest);
  835.             }catch(Exception e){
  836.                 posizione = "LetturaParametriSicurezzaMessaggioPAResponse";
  837.                 erroreIntegrazione = ErroriIntegrazione.ERRORE_5XX_GENERICO_PROCESSAMENTO_MESSAGGIO.
  838.                         get5XX_ErroreProcessamento(e,CodiceErroreIntegrazione.CODICE_536_CONFIGURAZIONE_NON_DISPONIBILE);
  839.                 configException = e;
  840.                 integrationFunctionError = IntegrationFunctionError.INTERNAL_RESPONSE_ERROR;
  841.             }
  842.             if(erroreIntegrazione==null){
  843.                 try{
  844.                     mtomConfig=this.localForwardParameter.getConfigurazionePdDReader().getMTOMProcessorForSender(this.pa);
  845.                 }catch(Exception e){
  846.                     posizione = "LetturaParametriMTOMProcessorPAResponse";
  847.                     erroreIntegrazione = ErroriIntegrazione.ERRORE_5XX_GENERICO_PROCESSAMENTO_MESSAGGIO.
  848.                             get5XX_ErroreProcessamento(e,CodiceErroreIntegrazione.CODICE_536_CONFIGURAZIONE_NON_DISPONIBILE);
  849.                     configException = e;
  850.                     integrationFunctionError = IntegrationFunctionError.INTERNAL_RESPONSE_ERROR;
  851.                 }
  852.             }       
  853.             if(erroreIntegrazione==null){
  854.                 mtomProcessor = new MTOMProcessor(mtomConfig, securityConfig, TipoPdD.APPLICATIVA, 
  855.                         this.localForwardParameter.getMsgDiag(), this.localForwardParameter.getLog(),
  856.                         this.localForwardParameter.getPddContext());
  857.             }
  858.             
  859.             /* *** MTOM Processor BeforeSecurity  *** */
  860.             if(mtomProcessor!=null && erroreIntegrazione==null){
  861.                 try{
  862.                     mtomProcessor.mtomBeforeSecurity(responseMessage, RuoloMessaggio.RISPOSTA);
  863.                 }catch(Exception e){
  864.                     logDiagnosticError = false; // L'errore viene registrato dentro il metodo mtomProcessor.mtomBeforeSecurity
  865.                     
  866.                     posizione = "MTOMProcessor(BeforeSec-"+mtomProcessor.getMTOMProcessorType()+")PAResponse";
  867.                     erroreIntegrazione = ErroriIntegrazione.ERRORE_5XX_GENERICO_PROCESSAMENTO_MESSAGGIO.
  868.                             get5XX_ErroreProcessamento(e,CodiceErroreIntegrazione.CODICE_557_MTOM_PROCESSOR_ERROR);
  869.                     configException = e;
  870.                     integrationFunctionError = IntegrationFunctionError.ATTACHMENTS_PROCESSING_RESPONSE_FAILED;
  871.                 }
  872.             }
  873.             
  874.             /* *** MessageSecurity (InitContext) *** */
  875.             MessageSecurityContext messageSecurityContext = null;
  876.             if(erroreIntegrazione==null && securityConfig!=null && securityConfig.getFlowParameters()!=null){
  877.                 if(securityConfig.getFlowParameters().size() > 0){
  878.                     try{
  879.                         this.localForwardParameter.getMsgDiag().mediumDebug("Inizializzazione contesto di Message Security (PA) della risposta ...");
  880.                         MessageSecurityContextParameters contextParameters = new MessageSecurityContextParameters();
  881.                         contextParameters.setUseActorDefaultIfNotDefined(this.propertiesReader.isGenerazioneActorDefault(this.localForwardParameter.getImplementazionePdDMittente()));
  882.                         contextParameters.setActorDefault(this.propertiesReader.getActorDefault(this.localForwardParameter.getImplementazionePdDMittente()));
  883.                         contextParameters.setLog(this.localForwardParameter.getLog());
  884.                         contextParameters.setFunctionAsClient(SecurityConstants.SECURITY_CLIENT);
  885.                         contextParameters.setPrefixWsuId(this.propertiesReader.getPrefixWsuId());
  886.                         contextParameters.setIdFruitore(this.richiestaDelegata.getIdSoggettoFruitore());
  887.                         contextParameters.setIdServizio(this.richiestaDelegata.getIdServizio());
  888.                         contextParameters.setPddFruitore(this.localForwardParameter.getIdPdDMittente());
  889.                         contextParameters.setPddErogatore(this.localForwardParameter.getIdPdDDestinatario());
  890.                         messageSecurityContext = messageSecurityFactory.getMessageSecurityContext(contextParameters);
  891.                         messageSecurityContext.setOutgoingProperties(securityConfig.getFlowParameters());
  892.                         this.localForwardParameter.getMsgDiag().mediumDebug("Inizializzazione contesto di Message Security (PA) della risposta completata con successo");
  893.                         
  894.                     }catch(Exception e){
  895.                         posizione = "MessageSecurityPortaApplicativaResponseFlowInitContext";
  896.                         erroreIntegrazione = ErroriIntegrazione.ERRORE_5XX_GENERICO_PROCESSAMENTO_MESSAGGIO.
  897.                                 get5XX_ErroreProcessamento(e,CodiceErroreIntegrazione.CODICE_536_CONFIGURAZIONE_NON_DISPONIBILE);
  898.                         configException = e;
  899.                         integrationFunctionError = IntegrationFunctionError.INTERNAL_RESPONSE_ERROR;
  900.                     }
  901.                 }
  902.             }
  903.             
  904.             /* *** ReadSecurityInformation *** */
  905.             if(erroreIntegrazione==null && messageSecurityContext!=null){
  906.                 IDigestReader digestReader = null;
  907.                 if(messageSecurityContext != null) {
  908.                     digestReader = messageSecurityContext.getDigestReader(responseMessage!=null ? responseMessage.getFactory() : OpenSPCoop2MessageFactory.getDefaultMessageFactory());
  909.                 }
  910.                 if(digestReader!=null) {
  911.                     try{
  912.                         this.localForwardParameter.getMsgDiag().mediumDebug("ReadSecurityInformation (PA-Response) ...");
  913.                         IValidazioneSemantica validazioneSemantica = this.localForwardParameter.getProtocolFactory().createValidazioneSemantica(state);
  914.                         this.securityInfoResponse = validazioneSemantica.readSecurityInformation(digestReader,responseMessage);
  915.                     }catch(Exception e){
  916.                         posizione = "LetturaInformazioniSicurezzaPAResponse";
  917.                         erroreIntegrazione = ErroriIntegrazione.ERRORE_5XX_GENERICO_PROCESSAMENTO_MESSAGGIO.
  918.                             get5XX_ErroreProcessamento(CodiceErroreIntegrazione.CODICE_549_SECURITY_INFO_READER_ERROR);
  919.                         configException = e;
  920.                         integrationFunctionError = IntegrationFunctionError.MESSAGE_SECURITY_RESPONSE_FAILED;
  921.                     }
  922.                 }
  923.             }
  924.             
  925.             /* *** MessageSecurity *** */
  926.             if(erroreIntegrazione==null && messageSecurityContext!=null){
  927.                 try{
  928.                     if(org.openspcoop2.security.message.engine.WSSUtilities.isNormalizeToSaajImpl(messageSecurityContext)){
  929.                         this.localForwardParameter.getMsgDiag().mediumDebug("Normalize to saajImpl");
  930.                         //System.out.println("InoltroBusteEgov.request.normalize");
  931.                         responseMessage = responseMessage.normalizeToSaajImpl();
  932.                         this.responseMessageAfterProcess = responseMessage; // per aggiornare il messaggio fuori dall'engine
  933.                     }
  934.                     String tipoSicurezza = SecurityConstants.convertActionToString(messageSecurityContext.getOutgoingProperties());
  935.                     this.localForwardParameter.getMsgDiag().addKeyword(CostantiPdD.KEY_TIPO_SICUREZZA_MESSAGGIO_RISPOSTA, tipoSicurezza);
  936.                     this.localForwardParameter.getMsgDiag().logPersonalizzato(MsgDiagnosticiProperties.MSG_DIAG_RICEZIONE_BUSTE,"messageSecurity.processamentoRispostaInCorso");                    
  937.                     messageSecurityApply = true;
  938.                     DynamicMapBuilderUtils.injectDynamicMap(this.busta, this.requestInfo, pddContext, this.localForwardParameter.getLog());
  939.                     if(messageSecurityContext.processOutgoing(responseMessage,this.localForwardParameter.getPddContext(),
  940.                             getTransactionNullable()!=null ? getTransactionNullable().getTempiElaborazione() : null) == false){
  941.                         msgErrore = messageSecurityContext.getMsgErrore();
  942.                         codiceErroreCooperazione = messageSecurityContext.getCodiceErrore();
  943.                         this.localForwardParameter.getMsgDiag().addKeyword(CostantiPdD.KEY_ERRORE_PROCESSAMENTO , "["+codiceErroreCooperazione+"] "+msgErrore );
  944.                         this.localForwardParameter.getMsgDiag().logPersonalizzato(MsgDiagnosticiProperties.MSG_DIAG_RICEZIONE_BUSTE,"messageSecurity.processamentoRispostaInErrore");
  945.                     }
  946.                     else{
  947.                         this.localForwardParameter.getMsgDiag().logPersonalizzato(MsgDiagnosticiProperties.MSG_DIAG_RICEZIONE_BUSTE,"messageSecurity.processamentoRispostaEffettuato");
  948.                     }
  949.                 }catch(Exception e){
  950.                     this.localForwardParameter.getMsgDiag().addKeywordErroreProcessamento(e);
  951.                     this.localForwardParameter.getMsgDiag().logPersonalizzato(MsgDiagnosticiProperties.MSG_DIAG_RICEZIONE_BUSTE,"messageSecurity.processamentoRispostaInErrore");
  952.                     posizione = "MessageSecurityPortaApplicativaResponseFlow";
  953.                     erroreIntegrazione = ErroriIntegrazione.ERRORE_5XX_GENERICO_PROCESSAMENTO_MESSAGGIO.
  954.                             get5XX_ErroreProcessamento(e,CodiceErroreIntegrazione.CODICE_536_CONFIGURAZIONE_NON_DISPONIBILE);
  955.                     configException = e;
  956.                     integrationFunctionError = IntegrationFunctionError.MESSAGE_SECURITY_RESPONSE_FAILED;
  957.                 }
  958.             }
  959.             else{
  960.                 if(erroreIntegrazione==null){
  961.                     this.localForwardParameter.getMsgDiag().logPersonalizzato(MsgDiagnosticiProperties.MSG_DIAG_RICEZIONE_BUSTE,"messageSecurity.processamentoRispostaDisabilitato");
  962.                 }
  963.             }
  964.             
  965.             /* *** MTOM Processor AfterSecurity  *** */
  966.             if(mtomProcessor!=null && erroreIntegrazione==null){
  967.                 try{
  968.                     mtomProcessor.mtomAfterSecurity(responseMessage, RuoloMessaggio.RISPOSTA);
  969.                 }catch(Exception e){
  970.                     logDiagnosticError = false; // L'errore viene registrato dentro il metodo mtomProcessor.mtomAfterSecurity
  971.                     
  972.                     posizione = "MTOMProcessor(AfterSec-"+mtomProcessor.getMTOMProcessorType()+")PAResponse";
  973.                     erroreIntegrazione = ErroriIntegrazione.ERRORE_5XX_GENERICO_PROCESSAMENTO_MESSAGGIO.
  974.                             get5XX_ErroreProcessamento(e,CodiceErroreIntegrazione.CODICE_557_MTOM_PROCESSOR_ERROR);
  975.                     configException = e;
  976.                     integrationFunctionError = IntegrationFunctionError.ATTACHMENTS_PROCESSING_RESPONSE_FAILED;
  977.                 }
  978.             }
  979.             
  980.             /* *** Gestione eventuale errore  *** */
  981.             if(erroreIntegrazione!=null || codiceErroreCooperazione!= null){
  982.                 if(integrationFunctionError==null) {
  983.                     integrationFunctionError = IntegrationFunctionError.INTERNAL_RESPONSE_ERROR;
  984.                 }
  985.                 if(erroreIntegrazione!=null){
  986.                     if(logDiagnosticError){
  987.                         this.localForwardParameter.getMsgDiag().logErroreGenerico(erroreIntegrazione.getDescrizione(this.localForwardParameter.getProtocolFactory()), 
  988.                                 posizione);
  989.                     }
  990.                     this.responseMessageError = this.generatoreErrorePortaDelegata.build(pddContext, integrationFunctionError,
  991.                             erroreIntegrazione,configException,
  992.                             (responseMessage!=null ? responseMessage.getParseException() : null));
  993.                 }else{
  994.                     Eccezione ecc = Eccezione.getEccezioneValidazione(ErroriCooperazione.MESSAGE_SECURITY.getErroreMessageSecurity(msgErrore, codiceErroreCooperazione),
  995.                             this.localForwardParameter.getProtocolFactory());
  996.                     if(logDiagnosticError){
  997.                         this.localForwardParameter.getMsgDiag().logErroreGenerico(ecc.getDescrizione(this.localForwardParameter.getProtocolFactory()), 
  998.                                 posizione);
  999.                     }
  1000.                     this.responseMessageError = this.generatoreErrorePortaDelegata.build(pddContext, integrationFunctionError,
  1001.                             ecc,this.richiestaDelegata.getIdSoggettoFruitore(),null);
  1002.                 }
  1003.                 if(logDiagnosticError==false){
  1004.                     // comunque effettuo log nel core. Puo' darsi in alcuni casi che non venga registrato (es. NullPointer)
  1005.                     this.localForwardParameter.getLog().error("("+posizione+") "+Utilities.readFirstErrorValidMessageFromException(configException),configException);
  1006.                 }
  1007.             }
  1008.             if(this.responseMessageError!=null){
  1009.                 return false;
  1010.             }

  1012.             
  1013.             
  1014.             
  1015.             
  1016.             
  1017.             
  1018.             /* ****************** PORTA DELEGATA **************************** */
  1019.             
  1020.             /* *** Init MTOM Processor / SecurityContext *** */
  1021.             this.localForwardParameter.getMsgDiag().mediumDebug("init MTOM Processor / SecurityContext (PD-Response) ...");
  1022.             erroreIntegrazione = null;
  1023.             codiceErroreCooperazione = null;
  1024.             configException = null;
  1025.             securityConfig = null;
  1026.             mtomConfig = null;
  1027.             mtomProcessor = null;
  1028.             msgErrore = null;
  1029.             posizione = null;
  1030.             messageSecurityContext = null;
  1031.             logDiagnosticError = true;
  1032.             integrationFunctionError = null;
  1033.             try{
  1034.                 securityConfig=this.localForwardParameter.getConfigurazionePdDReader().getMessageSecurityForReceiver(this.pd, this.localForwardParameter.getLog(), responseMessage, this.busta, this.requestInfo, this.localForwardParameter.getPddContext(),
  1035.                         this.securityConfigPDRequest);
  1036.             }catch(Exception e){
  1037.                 posizione = "LetturaParametriSicurezzaMessaggioPDResponse";
  1038.                 erroreIntegrazione = ErroriIntegrazione.ERRORE_5XX_GENERICO_PROCESSAMENTO_MESSAGGIO.
  1039.                         get5XX_ErroreProcessamento(e,CodiceErroreIntegrazione.CODICE_536_CONFIGURAZIONE_NON_DISPONIBILE);
  1040.                 configException = e;
  1041.                 integrationFunctionError = IntegrationFunctionError.INTERNAL_RESPONSE_ERROR;
  1042.             }
  1043.             if(erroreIntegrazione==null){
  1044.                 try{
  1045.                     mtomConfig=this.localForwardParameter.getConfigurazionePdDReader().getMTOMProcessorForReceiver(this.pd);
  1046.                 }catch(Exception e){
  1047.                     posizione = "LetturaParametriMTOMProcessorPDResponse";
  1048.                     erroreIntegrazione = ErroriIntegrazione.ERRORE_5XX_GENERICO_PROCESSAMENTO_MESSAGGIO.
  1049.                             get5XX_ErroreProcessamento(e,CodiceErroreIntegrazione.CODICE_536_CONFIGURAZIONE_NON_DISPONIBILE);
  1050.                     configException = e;
  1051.                     integrationFunctionError = IntegrationFunctionError.INTERNAL_RESPONSE_ERROR;
  1052.                 }
  1053.             }       
  1054.             if(erroreIntegrazione==null){
  1055.                 mtomProcessor = new MTOMProcessor(mtomConfig, securityConfig, TipoPdD.DELEGATA, 
  1056.                         this.localForwardParameter.getMsgDiag(), this.localForwardParameter.getLog(),
  1057.                         this.localForwardParameter.getPddContext());
  1058.             }
  1059.             
  1060.             /* *** MTOM Processor BeforeSecurity  *** */
  1061.             if(mtomProcessor!=null && erroreIntegrazione==null){
  1062.                 try{
  1063.                     mtomProcessor.mtomBeforeSecurity(responseMessage, RuoloMessaggio.RISPOSTA);
  1064.                 }catch(Exception e){
  1065.                     logDiagnosticError = false; // L'errore viene registrato dentro il metodo mtomProcessor.mtomBeforeSecurity
  1066.                     
  1067.                     posizione = "MTOMProcessor(BeforeSec-"+mtomProcessor.getMTOMProcessorType()+")PDResponse";
  1068.                     erroreIntegrazione = ErroriIntegrazione.ERRORE_5XX_GENERICO_PROCESSAMENTO_MESSAGGIO.
  1069.                             get5XX_ErroreProcessamento(e,CodiceErroreIntegrazione.CODICE_557_MTOM_PROCESSOR_ERROR);
  1070.                     configException = e;
  1071.                     integrationFunctionError = IntegrationFunctionError.ATTACHMENTS_PROCESSING_RESPONSE_FAILED;
  1072.                 }
  1073.             }
  1074.             
  1075.             /* *** MessageSecurity *** */
  1076.             if(erroreIntegrazione==null){
  1077.                 if(securityConfig!=null && securityConfig.getFlowParameters()!=null &&
  1078.                         securityConfig.getFlowParameters().size() > 0){
  1079.                     try{
  1080.                         this.localForwardParameter.getMsgDiag().mediumDebug("Inizializzazione contesto di Message Security (PD) della risposta ...");
  1081.                         
  1082.                         if(messageSecurityApply){
  1083.                             
  1084.                             OpenSPCoop2SoapMessage soapMessage = responseMessage.castAsSoap();
  1085.                             
  1086.                             // Per poter applicare anche questa config devo rigenerare tutto il messaggio
  1087. //                          requestMessage.writeTo(System.out, false);
  1088.                             DOMSource s = (DOMSource) soapMessage.getSOAPPart().getContent();
  1089.                             Node n = s.getNode();
  1090.                             MessageXMLUtils xmlUtils = MessageXMLUtils.getInstance(responseMessage.getFactory());
  1091.                             byte[] bytes = xmlUtils.toByteArray(n);
  1092. //                          System.out.println("A:"+new String(bytes));
  1093.                             soapMessage.getSOAPPart().setContent(new DOMSource(xmlUtils.newElement(bytes)));
  1094. //                          System.out.println("B");
  1095. //                          requestMessage.writeTo(System.out, false);
  1096.                         }
  1097.     
  1098.                         MessageSecurityContextParameters contextParameters = new MessageSecurityContextParameters();
  1099.                         contextParameters.setUseActorDefaultIfNotDefined(this.propertiesReader.isGenerazioneActorDefault(this.localForwardParameter.getImplementazionePdDDestinatario()));
  1100.                         contextParameters.setActorDefault(this.propertiesReader.getActorDefault(this.localForwardParameter.getImplementazionePdDDestinatario()));
  1101.                         contextParameters.setLog(this.localForwardParameter.getLog());
  1102.                         contextParameters.setFunctionAsClient(SecurityConstants.SECURITY_SERVER);
  1103.                         contextParameters.setPrefixWsuId(this.propertiesReader.getPrefixWsuId());
  1104.                         contextParameters.setIdFruitore(this.richiestaDelegata.getIdSoggettoFruitore());
  1105.                         contextParameters.setIdServizio(this.richiestaDelegata.getIdServizio());
  1106.                         contextParameters.setPddFruitore(this.localForwardParameter.getIdPdDMittente());
  1107.                         contextParameters.setPddErogatore(this.localForwardParameter.getIdPdDDestinatario());
  1108.                         messageSecurityContext = messageSecurityFactory.getMessageSecurityContext(contextParameters);
  1109.                         messageSecurityContext.setIncomingProperties(securityConfig.getFlowParameters());
  1110.                         this.localForwardParameter.getMsgDiag().mediumDebug("Inizializzazione contesto di Message Security (PD) della risposta completata con successo");
  1111.                         
  1112.                         if(org.openspcoop2.security.message.engine.WSSUtilities.isNormalizeToSaajImpl(messageSecurityContext)){
  1113.                             this.localForwardParameter.getMsgDiag().mediumDebug("Normalize to saajImpl");
  1114.                             //System.out.println("InoltroBusteEgov.request.normalize");
  1115.                             responseMessage = responseMessage.normalizeToSaajImpl();
  1116.                             this.responseMessageAfterProcess = responseMessage; // per aggiornare il messaggio fuori dall'engine
  1117.                         }
  1118.                         String tipoSicurezza = SecurityConstants.convertActionToString(messageSecurityContext.getIncomingProperties());
  1119.                         this.localForwardParameter.getMsgDiag().addKeyword(CostantiPdD.KEY_TIPO_SICUREZZA_MESSAGGIO_RISPOSTA, tipoSicurezza);
  1120.                         this.localForwardParameter.getMsgDiag().logPersonalizzato(MsgDiagnosticiProperties.MSG_DIAG_INOLTRO_BUSTE,"messageSecurity.processamentoRispostaInCorso");                  
  1121.                         DynamicMapBuilderUtils.injectDynamicMap(this.busta, this.requestInfo, this.localForwardParameter.getPddContext(), this.localForwardParameter.getLog());
  1122.                         if(messageSecurityContext.processIncoming(responseMessage,this.busta,this.localForwardParameter.getPddContext(),
  1123.                                 getTransactionNullable()!=null ? getTransactionNullable().getTempiElaborazione() : null) == false){
  1124.                             msgErrore = messageSecurityContext.getMsgErrore();
  1125.                             codiceErroreCooperazione = messageSecurityContext.getCodiceErrore();
  1126.                             this.localForwardParameter.getMsgDiag().addKeyword(CostantiPdD.KEY_ERRORE_PROCESSAMENTO , "["+codiceErroreCooperazione+"] "+msgErrore );
  1127.                             this.localForwardParameter.getMsgDiag().logPersonalizzato(MsgDiagnosticiProperties.MSG_DIAG_INOLTRO_BUSTE,"messageSecurity.processamentoRispostaInErrore");
  1128.                         }
  1129.                         else{
  1130.                             this.localForwardParameter.getMsgDiag().logPersonalizzato(MsgDiagnosticiProperties.MSG_DIAG_INOLTRO_BUSTE,"messageSecurity.processamentoRispostaEffettuato");
  1131.                         }
  1132.                     }catch(Exception e){
  1133.                         this.localForwardParameter.getMsgDiag().addKeywordErroreProcessamento(e);
  1134.                         this.localForwardParameter.getMsgDiag().logPersonalizzato(MsgDiagnosticiProperties.MSG_DIAG_INOLTRO_BUSTE,"messageSecurity.processamentoRispostaInErrore");
  1135.                         posizione = "MessageSecurityPortaDelegataResponseFlow";
  1136.                         erroreIntegrazione = ErroriIntegrazione.ERRORE_5XX_GENERICO_PROCESSAMENTO_MESSAGGIO.
  1137.                                 get5XX_ErroreProcessamento(e,CodiceErroreIntegrazione.CODICE_536_CONFIGURAZIONE_NON_DISPONIBILE);
  1138.                         configException = e;
  1139.                         integrationFunctionError = IntegrationFunctionError.MESSAGE_SECURITY_RESPONSE_FAILED;
  1140.                     }
  1141.                 }
  1142.                 else{
  1143.                     this.localForwardParameter.getMsgDiag().logPersonalizzato(MsgDiagnosticiProperties.MSG_DIAG_INOLTRO_BUSTE,"messageSecurity.processamentoRispostaDisabilitato");                 
  1144.                 }
  1145.             }
  1146.             
  1147.             /* *** ReadSecurityInformation *** */
  1148.             if(erroreIntegrazione==null && codiceErroreCooperazione==null){
  1149.                 IDigestReader digestReader = null;
  1150.                 if(messageSecurityContext != null) {
  1151.                     digestReader = messageSecurityContext.getDigestReader(responseMessage!=null ? responseMessage.getFactory() : OpenSPCoop2MessageFactory.getDefaultMessageFactory());
  1152.                 }
  1153.                 if(digestReader!=null){
  1154.                     try{
  1155.                         this.localForwardParameter.getMsgDiag().mediumDebug("ReadSecurityInformation (PD-Response) ...");
  1156.                         IValidazioneSemantica validazioneSemantica = this.localForwardParameter.getProtocolFactory().createValidazioneSemantica(state);
  1157.                         this.securityInfoResponse = validazioneSemantica.readSecurityInformation(digestReader,responseMessage);
  1158.                     }catch(Exception e){
  1159.                         posizione = "LetturaInformazioniSicurezzaPDResponse";
  1160.                         erroreIntegrazione = ErroriIntegrazione.ERRORE_5XX_GENERICO_PROCESSAMENTO_MESSAGGIO.
  1161.                             get5XX_ErroreProcessamento(CodiceErroreIntegrazione.CODICE_549_SECURITY_INFO_READER_ERROR);
  1162.                         configException = e;
  1163.                         integrationFunctionError = IntegrationFunctionError.MESSAGE_SECURITY_RESPONSE_FAILED;
  1164.                     }
  1165.                 }
  1166.             }
  1167.             
  1168.             /* *** MTOM Processor AfterSecurity  *** */
  1169.             if(mtomProcessor!=null && erroreIntegrazione==null){
  1170.                 try{
  1171.                     mtomProcessor.mtomAfterSecurity(responseMessage, RuoloMessaggio.RISPOSTA);
  1172.                 }catch(Exception e){
  1173.                     logDiagnosticError = false; // L'errore viene registrato dentro il metodo mtomProcessor.mtomAfterSecurity
  1174.                     
  1175.                     posizione = "MTOMProcessor(AfterSec-"+mtomProcessor.getMTOMProcessorType()+")PDResponse";
  1176.                     erroreIntegrazione = ErroriIntegrazione.ERRORE_5XX_GENERICO_PROCESSAMENTO_MESSAGGIO.
  1177.                             get5XX_ErroreProcessamento(e,CodiceErroreIntegrazione.CODICE_557_MTOM_PROCESSOR_ERROR);
  1178.                     configException = e;
  1179.                     integrationFunctionError = IntegrationFunctionError.ATTACHMENTS_PROCESSING_RESPONSE_FAILED;
  1180.                 }
  1181.             }
  1182.             
  1183.             /* *** Gestione eventuale errore  *** */
  1184.             if(erroreIntegrazione!=null || codiceErroreCooperazione!= null){
  1185.                 if(integrationFunctionError==null) {
  1186.                     integrationFunctionError = IntegrationFunctionError.INTERNAL_RESPONSE_ERROR;
  1187.                 }
  1188.                 if(erroreIntegrazione!=null){
  1189.                     if(logDiagnosticError){
  1190.                         this.localForwardParameter.getMsgDiag().logErroreGenerico(erroreIntegrazione.getDescrizione(this.localForwardParameter.getProtocolFactory()), 
  1191.                                 posizione);
  1192.                     }
  1193.                     this.responseMessageError = this.generatoreErrorePortaDelegata.build(pddContext, integrationFunctionError,
  1194.                             erroreIntegrazione,configException,
  1195.                             (responseMessage!=null ? responseMessage.getParseException() : null));
  1196.                 }else{
  1197.                     Eccezione ecc = Eccezione.getEccezioneValidazione(ErroriCooperazione.MESSAGE_SECURITY.getErroreMessageSecurity(msgErrore, codiceErroreCooperazione),
  1198.                             this.localForwardParameter.getProtocolFactory());
  1199.                     if(logDiagnosticError){
  1200.                         this.localForwardParameter.getMsgDiag().logErroreGenerico(ecc.getDescrizione(this.localForwardParameter.getProtocolFactory()), 
  1201.                                 posizione);
  1202.                     }
  1203.                     this.responseMessageError = this.generatoreErrorePortaDelegata.build(pddContext, integrationFunctionError,
  1204.                             ecc,this.richiestaDelegata.getIdSoggettoFruitore(),null);
  1205.                 }
  1206.                 if(logDiagnosticError==false){
  1207.                     // comunque effettuo log nel core. Puo' darsi in alcuni casi che non venga registrato (es. NullPointer)
  1208.                     this.localForwardParameter.getLog().error("("+posizione+") "+Utilities.readFirstErrorValidMessageFromException(configException),configException);
  1209.                 }
  1210.             }
  1211.             if(this.responseMessageError!=null){
  1212.                 return false;
  1213.             }

  1215.             
  1216.             
  1217.             
  1218.             
  1219.             
  1220.             return true;
  1221.             
  1222.             
  1223.         }catch(Exception e){
  1224.             throw new LocalForwardException(e.getMessage(),e);
  1225.         }
  1226.         
  1227.     }
  1228.     
  1229.     
  1230.     
  1231.     
  1232.     
  1233.     
  1234.     
  1235.     
  1236.     
  1237.     /* ***** SEND RESPONSE ******** */
  1238.     
  1239.     public void sendErrore(PdDContext pddContext, ErroreIntegrazione errore,Throwable eErrore,ParseException parseException) throws LocalForwardException{
  1240.     
  1241.         try{
  1242.         
  1243.             IntegrationFunctionError integrationFunctionError = getIntegrationFunctionError(pddContext);
  1244.             
  1245.             OpenSPCoop2Message responseMessageError = 
  1246.                     this.generatoreErrorePortaDelegata.build(pddContext, integrationFunctionError,errore,eErrore,parseException);
  1247.             
  1248.             // Retry-After
  1249.             if(integrationFunctionError!=null && 
  1250.                     (
  1251.                             IntegrationFunctionError.SERVICE_UNAVAILABLE.equals(integrationFunctionError)
  1252.                             ||
  1253.                             IntegrationFunctionError.ENDPOINT_REQUEST_TIMED_OUT.equals(integrationFunctionError)
  1254.                     )
  1255.                     ) {
  1256.                 boolean isEnabled = this.propertiesReader.isEnabledServiceUnavailableRetryAfterPAConnectionFailed();
  1257.                 Integer retryAfterSeconds = this.propertiesReader.getServiceUnavailableRetryAfterSecondsPAConnectionFailed();
  1258.                 Integer retryAfterBackOffSeconds = this.propertiesReader.getServiceUnavailableRetryAfterSecondsRandomBackoffPAConnectionFailed();
  1259.                 if( isEnabled &&
  1260.                     retryAfterSeconds!=null && retryAfterSeconds>0) {
  1261.                     int seconds = retryAfterSeconds;
  1262.                     if(retryAfterBackOffSeconds!=null && retryAfterBackOffSeconds>0) {
  1263.                         seconds = seconds + ServicesUtils.getRandom().nextInt(retryAfterBackOffSeconds);
  1264.                     }
  1265.                     responseMessageError.forceTransportHeader(HttpConstants.RETRY_AFTER, seconds+"");
  1266.                 }
  1267.             }
  1268.             
  1269.             if(eErrore instanceof HandlerException){
  1270.                 HandlerException he = (HandlerException) eErrore;
  1271.                 he.customized(responseMessageError);
  1272.             }
  1273.             this.sendErrore(responseMessageError);
  1274.             
  1275.         }catch(Exception e){
  1276.             throw new LocalForwardException(e.getMessage(),e);
  1277.         }   
  1278.     }
  1279.     
  1280.     public void sendErrore(PdDContext pddContext, Eccezione errore,IDSoggetto dominio,ParseException parseException) throws LocalForwardException{
  1281.         
  1282.         try{
  1283.         
  1284.             IntegrationFunctionError integrationFunctionError = getIntegrationFunctionError(pddContext);
  1285.             
  1286.             OpenSPCoop2Message responseMessageError = 
  1287.                     this.generatoreErrorePortaDelegata.build(pddContext, integrationFunctionError,errore,dominio,parseException);
  1288.             this.sendErrore(responseMessageError);
  1289.             
  1290.         }catch(Exception e){
  1291.             throw new LocalForwardException(e.getMessage(),e);
  1292.         }   
  1293.     }
  1294.     
  1295.     public void sendErrore(OpenSPCoop2Message responseMessageError) throws LocalForwardException{
  1296.         
  1297.         try{
  1298.         
  1299.             this.ejbUtils.sendRispostaApplicativaErrore(responseMessageError,this.richiestaDelegata,true,this.pd,this.sa);
  1300.             
  1301.         }catch(Exception e){
  1302.             throw new LocalForwardException(e.getMessage(),e);
  1303.         }   
  1304.     }
  1305.     
  1306.     public void sendResponse(String idRisposta) throws LocalForwardException{
  1307.         
  1308.         try{
  1309.         
  1310.             GestoreMessaggi msgResponse = null;
  1311.             
  1312.             this.localForwardParameter.getMsgDiag().mediumDebug("Send risposta applicativa...");
  1313.             this.ejbUtils.setIdMessage(idRisposta);
  1314.             msgResponse = this.ejbUtils.sendRispostaApplicativa(this.richiestaDelegata,this.pd,this.sa);
  1315.                         
  1316.             // Aggiornamento cache messaggio
  1317.             if(msgResponse!=null)
  1318.                 msgResponse.addMessaggiIntoCache_readFromTable(SbustamentoRisposte.ID_MODULO, "risposte");

  1320.             // Aggiornamento cache proprietario messaggio
  1321.             if(msgResponse!=null)
  1322.                 msgResponse.addProprietariIntoCache_readFromTable(SbustamentoRisposte.ID_MODULO, "risposte",this.localForwardParameter.getIdRequest(),false);
  1323.             
  1324.         }catch(Exception e){
  1325.             throw new LocalForwardException(e.getMessage(),e);
  1326.         }   
  1327.     }
  1328. }
Created with JaCoCo 0.8.8.202204050719