RicezioneContenutiApplicativiServiceUtils.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.services.service;

  23. import java.util.Date;
  24. import java.util.HashMap;
  25. import java.util.List;
  26. import java.util.Map;

  28. import javax.servlet.http.HttpServletRequest;

  30. import org.apache.commons.lang.StringUtils;
  31. import org.openspcoop2.core.config.CorsConfigurazione;
  32. import org.openspcoop2.core.config.PortaDelegata;
  33. import org.openspcoop2.core.config.constants.StatoFunzionalita;
  34. import org.openspcoop2.core.config.constants.TipoGestioneCORS;
  35. import org.openspcoop2.core.constants.TipoPdD;
  36. import org.openspcoop2.core.id.IDPortaDelegata;
  37. import org.openspcoop2.core.id.IDServizio;
  38. import org.openspcoop2.core.id.IDSoggetto;
  39. import org.openspcoop2.core.registry.PortaDominio;
  40. import org.openspcoop2.core.registry.Soggetto;
  41. import org.openspcoop2.core.transazioni.utils.PropertiesSerializator;
  42. import org.openspcoop2.message.config.ServiceBindingConfiguration;
  43. import org.openspcoop2.message.constants.MessageType;
  44. import org.openspcoop2.message.constants.ServiceBinding;
  45. import org.openspcoop2.message.soap.reader.OpenSPCoop2MessageSoapStreamReader;
  46. import org.openspcoop2.pdd.config.CachedConfigIntegrationReader;
  47. import org.openspcoop2.pdd.config.ConfigurazionePdDManager;
  48. import org.openspcoop2.pdd.config.OpenSPCoop2Properties;
  49. import org.openspcoop2.pdd.core.CostantiPdD;
  50. import org.openspcoop2.pdd.core.GestoreRichieste;
  51. import org.openspcoop2.pdd.core.PdDContext;
  52. import org.openspcoop2.pdd.core.handlers.GestoreHandlers;
  53. import org.openspcoop2.pdd.core.handlers.PostOutResponseContext;
  54. import org.openspcoop2.pdd.core.handlers.transazioni.PreInRequestHandler;
  55. import org.openspcoop2.pdd.core.transazioni.Transaction;
  56. import org.openspcoop2.pdd.core.transazioni.TransactionContext;
  57. import org.openspcoop2.pdd.logger.MsgDiagnosticiProperties;
  58. import org.openspcoop2.pdd.logger.MsgDiagnostico;
  59. import org.openspcoop2.pdd.services.OpenSPCoop2Startup;
  60. import org.openspcoop2.pdd.services.connector.ConnectorDispatcherInfo;
  61. import org.openspcoop2.pdd.services.connector.ConnectorDispatcherUtils;
  62. import org.openspcoop2.pdd.services.connector.ConnectorException;
  63. import org.openspcoop2.pdd.services.connector.messages.ConnectorInMessage;
  64. import org.openspcoop2.pdd.services.connector.messages.ConnectorOutMessage;
  65. import org.openspcoop2.pdd.services.core.RicezioneContenutiApplicativiContext;
  66. import org.openspcoop2.pdd.services.error.RicezioneContenutiApplicativiInternalErrorGenerator;
  67. import org.openspcoop2.protocol.basic.registry.IdentificazionePortaDelegata;
  68. import org.openspcoop2.protocol.basic.registry.ServiceIdentificationReader;
  69. import org.openspcoop2.protocol.registry.RegistroServiziManager;
  70. import org.openspcoop2.protocol.sdk.IProtocolFactory;
  71. import org.openspcoop2.protocol.sdk.builder.EsitoTransazione;
  72. import org.openspcoop2.protocol.sdk.constants.ErroriIntegrazione;
  73. import org.openspcoop2.protocol.sdk.constants.EsitoTransazioneName;
  74. import org.openspcoop2.protocol.sdk.constants.IDService;
  75. import org.openspcoop2.protocol.sdk.constants.IntegrationFunctionError;
  76. import org.openspcoop2.protocol.sdk.registry.IRegistryReader;
  77. import org.openspcoop2.protocol.sdk.registry.RegistryNotFound;
  78. import org.openspcoop2.protocol.sdk.state.IState;
  79. import org.openspcoop2.protocol.sdk.state.RequestInfo;
  80. import org.openspcoop2.protocol.sdk.state.RequestInfoConfigUtilities;
  81. import org.openspcoop2.protocol.sdk.state.URLProtocolContext;
  82. import org.openspcoop2.utils.date.DateManager;
  83. import org.openspcoop2.utils.transport.TransportUtils;
  84. import org.openspcoop2.utils.transport.http.ContentTypeUtilities;
  85. import org.openspcoop2.utils.transport.http.HttpConstants;
  86. import org.openspcoop2.utils.transport.http.HttpRequestMethod;
  87. import org.slf4j.Logger;

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

  98.     public static RicezionePropertiesConfig readPropertiesConfig(RequestInfo requestInfo, Logger logCore, IState state) {
  99.         if (requestInfo != null && requestInfo.getProtocolContext() != null && requestInfo.getProtocolContext().getInterfaceName() != null && !"".equals(requestInfo.getProtocolContext().getInterfaceName())) {
  100.             try {
  101.                 ConfigurazionePdDManager configurazionePdDManager = ConfigurazionePdDManager.getInstance(state);
  102.                 RegistroServiziManager registroServiziManager = RegistroServiziManager.getInstance(state);
  103.                 IDPortaDelegata idPD = new IDPortaDelegata();
  104.                 idPD.setNome(requestInfo.getProtocolContext().getInterfaceName());
  105.                 PortaDelegata pd = configurazionePdDManager.getPortaDelegataSafeMethod(idPD, requestInfo);
  106.                 if (pd != null) {
  107.                     RicezionePropertiesConfig config = new RicezionePropertiesConfig();
  108.                     
  109.                     config.setApiImplementation(configurazionePdDManager.getProprietaConfigurazione(pd));
  110.                     
  111.                     IDSoggetto idSoggettoProprietario = new IDSoggetto(pd.getTipoSoggettoProprietario(), pd.getNomeSoggettoProprietario());
  112.                     Soggetto soggetto = registroServiziManager.getSoggetto(idSoggettoProprietario, null, requestInfo);
  113.                     config.setSoggettoFruitore(registroServiziManager.getProprietaConfigurazione(soggetto));
  114.                     
  115.                     IDSoggetto idSoggettoErogatore = new IDSoggetto(pd.getSoggettoErogatore().getTipo(), pd.getSoggettoErogatore().getNome());
  116.                     Soggetto soggettoErogatore = registroServiziManager.getSoggetto(idSoggettoErogatore, null, requestInfo);
  117.                     config.setSoggettoErogatore(registroServiziManager.getProprietaConfigurazione(soggettoErogatore));
  118.                     
  119.                     return config;
  120.                 }
  121.             } catch (Exception e) {
  122.                 logCore.error("Errore durante la lettura delle proprietà di configurazione della porta delegata [" + requestInfo.getProtocolContext().getInterfaceName() + "]: " + e.getMessage(), e);
  123.             }

  125.             return null;
  126.         } else {
  127.             return null;
  128.         }
  129.     }
  130.     
  131.     public static ConnectorDispatcherInfo updatePortaDelegataRequestInfo(RequestInfo requestInfo, Logger logCore, 
  132.             ConnectorInMessage req, ConnectorOutMessage res, RicezioneContenutiApplicativiInternalErrorGenerator generatoreErrore,
  133.             ServiceIdentificationReader serviceIdentificationReader,
  134.             MsgDiagnostico msgDiag, PdDContext pddContextNullable) throws ConnectorException{
  135.         
  136.         if(requestInfo==null) {
  137.             throw new ConnectorException("Param requestInfo is null");
  138.         }
  139.         
  140.         URLProtocolContext protocolContext = requestInfo.getProtocolContext();
  141.         IProtocolFactory<?> pf = requestInfo.getProtocolFactory();
  142.         ServiceBindingConfiguration bindingConfig = requestInfo.getBindingConfig();
  143.         ServiceBinding integrationServiceBinding = requestInfo.getIntegrationServiceBinding();
  144.         ServiceBinding protocolServiceBinding = requestInfo.getProtocolServiceBinding();
  145.         IDService idModuloAsServiceNullable = req!=null ? req.getIdModuloAsIDService() : null; // null se si passa da IntegrationManager
  146.                 
  147.         IRegistryReader registryReader = serviceIdentificationReader.getRegistryReader();
  148.         CachedConfigIntegrationReader configIntegrationReader = (CachedConfigIntegrationReader) serviceIdentificationReader.getConfigIntegrationReader();
  149.         ConfigurazionePdDManager configurazionePdDManager = ConfigurazionePdDManager.getInstance();
  150.         
  151.         IDPortaDelegata idPD = null;
  152.         PortaDelegata pdDefault = null;
  153.         try{
  154.             if(requestInfo.getRequestConfig()!=null && requestInfo.getRequestConfig().getIdPortaDelegataDefault()!=null) {
  155.                 idPD = requestInfo.getRequestConfig().getIdPortaDelegataDefault();
  156.             }
  157.             else {
  158.                 idPD = serviceIdentificationReader.findPortaDelegata(protocolContext, true);
  159.                 if(requestInfo.getRequestConfig()!=null) {
  160.                     requestInfo.getRequestConfig().setIdPortaDelegataDefault(idPD);
  161.                 }
  162.             }
  163.         }catch(RegistryNotFound notFound){
  164.             if(pddContextNullable!=null) {
  165.                 pddContextNullable.addObject(org.openspcoop2.core.constants.Costanti.API_NON_INDIVIDUATA, "true");
  166.             }
  167.             // Non ha senso nel contesto di porta delegata
  168.             //if(bindingConfig.existsContextUrlMapping()==false){
  169.             logCore.error("Porta Delegata non trovata: "+notFound.getMessage(),notFound);
  170.             msgDiag.addKeywordErroreProcessamento(notFound);
  171.             msgDiag.logPersonalizzato(MsgDiagnosticiProperties.MSG_DIAG_RICEZIONE_CONTENUTI_APPLICATIVI,"portaDelegataNonEsistente");
  172.             ConnectorDispatcherInfo c = ConnectorDispatcherUtils.doError(requestInfo, generatoreErrore, serviceIdentificationReader.getErroreIntegrazioneNotFound(), 
  173.                     IntegrationFunctionError.API_OUT_UNKNOWN, notFound, null, res, logCore, ConnectorDispatcherUtils.CLIENT_ERROR);
  174.             try {
  175.                 EsitoTransazione esito = requestInfo.getProtocolFactory().createEsitoBuilder().getEsito(requestInfo.getProtocolContext(),EsitoTransazioneName.API_NON_INDIVIDUATA);
  176.                 c.setEsitoTransazione(esito);
  177.             }catch(Throwable t) {
  178.                 logCore.error("Errore durante l'impostazione dell'esito 'API_NON_INDIVIDUATA'");
  179.             }
  180.             return c;
  181.             //}
  182.         }
  183.         if(idPD!=null){
  184.             
  185.             // da ora in avanti, avendo localizzato una PD, se avviene un errore genero l'errore stesso
  186.             protocolContext.setInterfaceName(idPD.getNome());
  187.             
  188.             // read IDServizio e IDSoggettoFruitore
  189.             IDSoggetto idSoggettoFruitore = null;
  190.             IDServizio idServizio = null;
  191.             if(requestInfo.getRequestConfig()!=null && 
  192.                     requestInfo.getRequestConfig().getIdServizio()!=null &&
  193.                     requestInfo.getRequestConfig().getIdFruitore()!=null) {
  194.                 idServizio = requestInfo.getRequestConfig().getIdServizio().clone(); // effettuo clone altrimenti viene cambiato dopo e la modifica potrebbe risultare anche in altri thread
  195.                 idSoggettoFruitore = requestInfo.getRequestConfig().getIdFruitore().clone(); // effettuo clone per i motivi sopra
  196.             }
  197.             else {
  198.                 if(idPD.getIdentificativiFruizione()!=null){
  199.                     if(idPD.getIdentificativiFruizione().getSoggettoFruitore()!=null) {
  200.                         idSoggettoFruitore = idPD.getIdentificativiFruizione().getSoggettoFruitore().clone(); // effettuo clone altrimenti nella cache vengono memorizzate le informazioni impostate dopo!
  201.                     }
  202.                     if( idPD.getIdentificativiFruizione().getIdServizio()!=null) {
  203.                         idServizio = idPD.getIdentificativiFruizione().getIdServizio().clone(); // effettuo clone altrimenti nella cache viene memorizzata l'azione impostata dopo!
  204.                     }
  205.                 }
  206.                 
  207.                 if(idServizio==null){
  208.                     try{
  209.                         idServizio = serviceIdentificationReader.convertToIDServizio(idPD);
  210.                         if(idServizio!=null) {
  211.                             idServizio = idServizio.clone(); // effettuo clone altrimenti nella cache viene memorizzata l'azione impostata dopo!
  212.                         }
  213.                     }catch(RegistryNotFound notFound){
  214.                         logCore.debug("Conversione Dati PortaDelegata in identificativo servizio fallita (notFound): "+notFound.getMessage(),notFound);
  215.                         msgDiag.addKeywordErroreProcessamento(notFound);
  216.                         msgDiag.logPersonalizzato(MsgDiagnosticiProperties.MSG_DIAG_RICEZIONE_CONTENUTI_APPLICATIVI,"portaDelegataNonEsistente");
  217.                         return ConnectorDispatcherUtils.doError(requestInfo, generatoreErrore, serviceIdentificationReader.getErroreIntegrazioneNotFound(), 
  218.                                 IntegrationFunctionError.API_OUT_UNKNOWN, notFound, null, res, logCore, ConnectorDispatcherUtils.CLIENT_ERROR);
  219.                     }
  220.                 }
  221.                 if(idSoggettoFruitore==null){
  222.                     try{
  223.                         idSoggettoFruitore = serviceIdentificationReader.convertToIDSoggettoFruitore(idPD);
  224.                     }catch(RegistryNotFound notFound){
  225.                         logCore.debug("Conversione Dati PortaDelegata in identificativo soggetto fruitore fallita (notFound): "+notFound.getMessage(),notFound);
  226.                         msgDiag.addKeywordErroreProcessamento(notFound);
  227.                         msgDiag.logPersonalizzato(MsgDiagnosticiProperties.MSG_DIAG_RICEZIONE_CONTENUTI_APPLICATIVI,"portaDelegataNonEsistente");
  228.                         return ConnectorDispatcherUtils.doError(requestInfo, generatoreErrore, serviceIdentificationReader.getErroreIntegrazioneNotFound(), 
  229.                                 IntegrationFunctionError.API_OUT_UNKNOWN, notFound, null, res, logCore, ConnectorDispatcherUtils.CLIENT_ERROR);
  230.                     }
  231.                 }
  232.                 
  233.                 if(requestInfo.getRequestConfig()!=null) {
  234.                     requestInfo.getRequestConfig().setIdServizio(idServizio);
  235.                     requestInfo.getRequestConfig().setIdFruitore(idSoggettoFruitore);
  236.                 }
  237.             }
  238.             
  239.             if(generatoreErrore!=null && idSoggettoFruitore!=null){
  240.                 generatoreErrore.updateDominio(idSoggettoFruitore);
  241.                 generatoreErrore.updateInformazioniCooperazione(idSoggettoFruitore, null);
  242.             }
  243.             
  244.             if(idServizio!=null){
  245.                 
  246.                 RegistroServiziManager registroServiziManager = RegistroServiziManager.getInstance();
  247.                 
  248.                 // Aggiorno service binding rispetto al servizio localizzato
  249.                 try{
  250.                     
  251.                     integrationServiceBinding = pf.createProtocolConfiguration().getIntegrationServiceBinding(idServizio, registryReader);
  252.                     requestInfo.setIntegrationServiceBinding(integrationServiceBinding);
  253.                     
  254.                     protocolServiceBinding = pf.createProtocolConfiguration().getProtocolServiceBinding(integrationServiceBinding, protocolContext);
  255.                     requestInfo.setProtocolServiceBinding(protocolServiceBinding);
  256.                     
  257.                     if(generatoreErrore!=null) {
  258.                         generatoreErrore.updateServiceBinding(integrationServiceBinding);
  259.                     }
  260.                 }catch(RegistryNotFound notFound){
  261.                     logCore.debug("Lettura ServiceBinding fallita (notFound): "+notFound.getMessage(),notFound);
  262.                     msgDiag.addKeywordErroreProcessamento(notFound);
  263.                     msgDiag.logPersonalizzato(MsgDiagnosticiProperties.MSG_DIAG_RICEZIONE_CONTENUTI_APPLICATIVI,"portaDelegataNonEsistente");
  264.                     return ConnectorDispatcherUtils.doError(requestInfo, generatoreErrore,
  265.                             ErroriIntegrazione.ERRORE_405_SERVIZIO_NON_TROVATO.getErroreIntegrazione(),
  266.                             IntegrationFunctionError.API_OUT_UNKNOWN, notFound, null, res, logCore, ConnectorDispatcherUtils.CLIENT_ERROR);
  267.                 }catch(Exception error){
  268.                     logCore.error("Lettura ServiceBinding fallita: "+error.getMessage(),error);
  269.                     msgDiag.addKeywordErroreProcessamento(error);
  270.                     msgDiag.logPersonalizzato(MsgDiagnosticiProperties.MSG_DIAG_RICEZIONE_CONTENUTI_APPLICATIVI,"portaDelegataNonEsistente");
  271.                     return ConnectorDispatcherUtils.doError(requestInfo, generatoreErrore,
  272.                             ErroriIntegrazione.ERRORE_5XX_GENERICO_PROCESSAMENTO_MESSAGGIO.get5XX_ErroreProcessamento("Lettura ServiceBinding fallita"),
  273.                             IntegrationFunctionError.INTERNAL_REQUEST_ERROR, error, null, res, logCore, ConnectorDispatcherUtils.GENERAL_ERROR);
  274.                 }
  275.                 
  276.                 // Provo ad ottenere il reader soap
  277.                 OpenSPCoop2MessageSoapStreamReader soapStreamReader = null;
  278.                 if(ServiceBinding.SOAP.equals(integrationServiceBinding) && !IDService.PORTA_DELEGATA_XML_TO_SOAP.equals(idModuloAsServiceNullable)) {
  279.                     try{
  280.                         if(req!=null) {
  281.                             soapStreamReader = req.getSoapReader();
  282.                         }
  283.                     }catch(Exception e){
  284.                         logCore.debug("SOAPStream lettura non riuscita: "+e.getMessage(),e);
  285.                     }
  286.                 }
  287.                 
  288.                 // PortaDelegata Default
  289.                 try{
  290.                     if(requestInfo.getRequestConfig()!=null && requestInfo.getRequestConfig().getPortaDelegataDefault()!=null) {
  291.                         pdDefault = requestInfo.getRequestConfig().getPortaDelegataDefault();
  292.                     }
  293.                     else {
  294.                         pdDefault = configurazionePdDManager.getPortaDelegata(idPD, null); // passo null volutamente, per non utilizzare la configurazione
  295.                         if(requestInfo.getRequestConfig()!=null) {
  296.                             requestInfo.getRequestConfig().setPortaDelegataDefault(pdDefault);
  297.                         }
  298.                     }
  299.                 }catch(Exception e){
  300.                     logCore.debug("Recupero porta default fallita: "+e.getMessage(),e);
  301.                 }
  302.                 
  303.                 // Verifico che la modalità di riconoscimento dell'azione sia compatibile
  304.                 RequestInfoConfigUtilities.checkRequestInfoConfig(pdDefault, logCore, integrationServiceBinding, soapStreamReader, requestInfo);
  305.                 // Aggiorno chiave per considerare anche il soapStreamReader
  306.                 GestoreRichieste.updateRequestConfig(requestInfo, integrationServiceBinding, soapStreamReader);
  307.                 if(requestInfo!=null && requestInfo.getRequestConfig()!=null && requestInfo.getRequestConfig().getIdServizio()!=null) {
  308.                     idServizio = requestInfo.getRequestConfig().getIdServizio(); // se ho fatto lo switch per chiave più specifica per soap, uso il nuovo oggetto per evitare che nella chiave precedente venga memorizzata l'azione
  309.                 }
  310.                 
  311.                 // provo a leggere anche l'azione
  312.                 // l'eventuale errore lo genero dopo
  313.                 try{
  314.                     //PortaDelegata pdSearchAzione = configIntegrationReader.getPortaDelegata(idPD);
  315.                     PortaDelegata pdSearchAzione = pdDefault;
  316.                     idServizio.setAzione(configIntegrationReader.getAzione(pdSearchAzione, protocolContext, requestInfo, requestInfo.getProtocolFactory(),soapStreamReader));
  317.                 }catch(Exception e){
  318.                     logCore.debug("Azione non trovata: "+e.getMessage(),e);
  319.                 }
  320.                                 
  321.                 // Lettura eventuale MessageFactory da utilizzare
  322.                 try {
  323.                     if(pdDefault!=null && pdDefault.getOptions()!=null && !StringUtils.isEmpty(pdDefault.getOptions())) {
  324.                         Map<String, List<String>> props = PropertiesSerializator.convertoFromDBColumnValue(pdDefault.getOptions());
  325.                         if(props!=null && props.size()>0) {
  326.                             String msgFactory = TransportUtils.getFirstValue(props,CostantiPdD.OPTIONS_MESSAGE_FACTORY);
  327.                             if(msgFactory!=null) {
  328.                                 requestInfo.setMessageFactory(msgFactory);
  329.                             }
  330.                         }
  331.                     }
  332.                 }catch(Throwable e){
  333.                     logCore.debug("Lettura Message Factory fallita: "+e.getMessage(),e);
  334.                 }
  335.                 
  336.                 // Lettura Azione
  337.                 try{
  338.                     if(requestInfo.getRequestConfig()!=null && requestInfo.getRequestConfig().getIdPortaDelegata()!=null) {
  339.                         idPD = requestInfo.getRequestConfig().getIdPortaDelegata();
  340.                         
  341.                         if(requestInfo.getRequestConfig().getIdPortaDelegataDefault()!=null && !requestInfo.getRequestConfig().getIdPortaDelegataDefault().equals(idPD)) {
  342.                             // pd specifica
  343.                             
  344.                             if(pddContextNullable!=null) {
  345.                                 pddContextNullable.addObject(CostantiPdD.NOME_PORTA_INVOCATA, requestInfo.getRequestConfig().getIdPortaDelegataDefault().getNome()); // prima di aggiornare la porta applicativa
  346.                             }
  347.                             
  348.                             msgDiag.addKeyword(CostantiPdD.KEY_PORTA_DELEGATA, idPD.getNome());
  349.                             msgDiag.updatePorta(idPD.getNome(), requestInfo);
  350.                             protocolContext.setInterfaceName(idPD.getNome());
  351.                         }
  352.                     }
  353.                     else {
  354.                         if(idServizio.getAzione()!=null) {
  355.                             IdentificazionePortaDelegata identificazione = new IdentificazionePortaDelegata(logCore, pf, 
  356.                                     serviceIdentificationReader.getRegistryReader(), serviceIdentificationReader.getConfigIntegrationReader(), // questi reader sono gia' 'cached'
  357.                                     requestInfo, pdDefault);
  358.                             if(identificazione.find(idServizio.getAzione())) {
  359.                                 IDPortaDelegata idPD_action = identificazione.getIDPortaDelegata(idServizio.getAzione());
  360.                                 if(idPD_action!=null) {
  361.                                     
  362.                                     if(pddContextNullable!=null) {
  363.                                         pddContextNullable.addObject(CostantiPdD.NOME_PORTA_INVOCATA, idPD.getNome()); // prima di aggiornare la porta delegata
  364.                                     }
  365.                                     
  366.                                     msgDiag.addKeyword(CostantiPdD.KEY_PORTA_DELEGATA, idPD_action.getNome());
  367.                                     msgDiag.updatePorta(idPD_action.getNome(),requestInfo);
  368.                                     protocolContext.setInterfaceName(idPD_action.getNome());
  369.                                     idPD = idPD_action;
  370.                                 }
  371.                             }
  372.                         }
  373.                         if(idPD!=null && requestInfo.getRequestConfig()!=null) {
  374.                             requestInfo.getRequestConfig().setIdPortaDelegata(idPD);
  375.                         }
  376.                     }
  377.                 }catch(Exception e){
  378.                     logCore.debug("Gestione porta specifica per azione fallita: "+e.getMessage(),e);
  379.                 }
  380.                 
  381.                 // SetPD usato poi successivamente
  382.                 if(idPD!=null && requestInfo.getRequestConfig()!=null && requestInfo.getRequestConfig().getPortaDelegata()==null) {
  383.                     try{
  384.                         PortaDelegata pd = configurazionePdDManager.getPortaDelegataSafeMethod(idPD, null); // passo null volutamente, per non utilizzare la configurazione
  385.                         requestInfo.getRequestConfig().setPortaDelegata(pd);
  386.                     }catch(Exception e){
  387.                         logCore.debug("Recupero porta delegata fallito: "+e.getMessage(),e);
  388.                     }
  389.                 }
  390.                 
  391.                 // Set identità soggetti erogatori usati poi successivamente
  392.                 if(idServizio!=null && idServizio.getSoggettoErogatore()!=null && requestInfo.getRequestConfig()!=null) {
  393.                     if(requestInfo.getRequestConfig().getSoggettoErogatoreRegistry()==null) {
  394.                         try{
  395.                             org.openspcoop2.core.registry.Soggetto soggettoRegistry = registroServiziManager.getSoggetto(idServizio.getSoggettoErogatore(), null, null); // passo null volutamente, per accedere alla configurazione
  396.                             requestInfo.getRequestConfig().setSoggettoErogatoreRegistry(soggettoRegistry);
  397.                         }catch(Exception e){
  398.                             logCore.debug("Recupero soggetto erogatore dal registro fallito: "+e.getMessage(),e);
  399.                         }
  400.                     }
  401.                     if(requestInfo.getRequestConfig().getSoggettoErogatoreConfig()==null) {
  402.                         try{
  403.                             org.openspcoop2.core.config.Soggetto soggettoConfig = configurazionePdDManager.getSoggetto(idServizio.getSoggettoErogatore(), null); // passo null volutamente, per accedere alla configurazione
  404.                             requestInfo.getRequestConfig().setSoggettoErogatoreConfig(soggettoConfig);
  405.                         }catch(Exception e){
  406.                             logCore.debug("Recupero soggetto erogatore dal registro fallito: "+e.getMessage(),e);
  407.                         }
  408.                     }
  409.                     if(requestInfo.getRequestConfig().getSoggettoErogatoreIdentificativoPorta()==null) {
  410.                         try{
  411.                             String idPorta = configurazionePdDManager.getIdentificativoPorta(idServizio.getSoggettoErogatore(), pf, null); // passo null volutamente, per accedere alla configurazione
  412.                             requestInfo.getRequestConfig().setSoggettoErogatoreIdentificativoPorta(idPorta);
  413.                         }catch(Exception e){
  414.                             logCore.debug("Recupero dati soggetto erogatore (identificativoPorta) dal registro fallito: "+e.getMessage(),e);
  415.                         }
  416.                     }
  417.                     if(requestInfo.getRequestConfig().getSoggettoErogatoreSoggettoVirtuale()==null) {
  418.                         try{
  419.                             boolean soggettoVirtuale = configurazionePdDManager.isSoggettoVirtuale(idServizio.getSoggettoErogatore(), null); // passo null volutamente, per accedere alla configurazione
  420.                             requestInfo.getRequestConfig().setSoggettoErogatoreSoggettoVirtuale(soggettoVirtuale);
  421.                         }catch(Exception e){
  422.                             logCore.debug("Recupero dati soggetto erogatore (soggettoVirtuale) dal registro fallito: "+e.getMessage(),e);
  423.                         }
  424.                     }
  425.                     if(requestInfo.getRequestConfig().getSoggettoErogatorePddReaded()==null) {
  426.                         try{
  427.                             if(requestInfo.getRequestConfig().getSoggettoErogatoreRegistry()!=null) {
  428.                                 if(requestInfo.getRequestConfig().getSoggettoErogatoreRegistry().getPortaDominio()!=null &&
  429.                                         StringUtils.isNotEmpty(requestInfo.getRequestConfig().getSoggettoErogatoreRegistry().getPortaDominio())) {
  430.                                     PortaDominio pdd = registroServiziManager.getPortaDominio(requestInfo.getRequestConfig().getSoggettoErogatoreRegistry().getPortaDominio(), null, null); // passo null volutamente, per accedere alla configurazione
  431.                                     requestInfo.getRequestConfig().setSoggettoErogatorePddReaded(true);
  432.                                     requestInfo.getRequestConfig().setSoggettoErogatorePdd(pdd);
  433.                                 }
  434.                                 else {
  435.                                     requestInfo.getRequestConfig().setSoggettoErogatorePddReaded(true);
  436.                                 }
  437.                             }
  438.                         }catch(Exception e){
  439.                             logCore.debug("Recupero dati soggetto erogatore (pdd) dal registro fallito: "+e.getMessage(),e);
  440.                         }
  441.                     }
  442.                     if(requestInfo.getRequestConfig().getSoggettoErogatoreImplementazionePdd()==null) {
  443.                         try{
  444.                             String impl = registroServiziManager.getImplementazionePdD(idServizio.getSoggettoErogatore(), null, null); // passo null volutamente, per accedere alla configurazione
  445.                             requestInfo.getRequestConfig().setSoggettoErogatoreImplementazionePdd(impl);
  446.                         }catch(Exception e){
  447.                             logCore.debug("Recupero dati soggetto erogatore (implementazione pdd) dal registro fallito: "+e.getMessage(),e);
  448.                         }
  449.                     }
  450.                 }
  451.                 
  452.                 // Set identità soggetti fruitori usati poi successivamente
  453.                 if(idSoggettoFruitore!=null && requestInfo.getRequestConfig()!=null) {
  454.                     if(requestInfo.getRequestConfig().getSoggettoFruitoreRegistry()==null) {
  455.                         try{
  456.                             org.openspcoop2.core.registry.Soggetto soggettoRegistry = registroServiziManager.getSoggetto(idSoggettoFruitore, null, null); // passo null volutamente, per accedere alla configurazione
  457.                             requestInfo.getRequestConfig().setSoggettoFruitoreRegistry(soggettoRegistry);
  458.                         }catch(Exception e){
  459.                             logCore.debug("Recupero soggetto fruitore dal registro fallito: "+e.getMessage(),e);
  460.                         }
  461.                     }
  462.                     if(requestInfo.getRequestConfig().getSoggettoFruitoreConfig()==null) {
  463.                         try{
  464.                             org.openspcoop2.core.config.Soggetto soggettoConfig = configurazionePdDManager.getSoggetto(idSoggettoFruitore, null); // passo null volutamente, per accedere alla configurazione
  465.                             requestInfo.getRequestConfig().setSoggettoFruitoreConfig(soggettoConfig);
  466.                         }catch(Exception e){
  467.                             logCore.debug("Recupero soggetto fruitore dal registro fallito: "+e.getMessage(),e);
  468.                         }
  469.                     }
  470.                     if(requestInfo.getRequestConfig().getSoggettoFruitoreIdentificativoPorta()==null) {
  471.                         try{
  472.                             String idPorta = configurazionePdDManager.getIdentificativoPorta(idSoggettoFruitore, pf, null); // passo null volutamente, per accedere alla configurazione
  473.                             requestInfo.getRequestConfig().setSoggettoFruitoreIdentificativoPorta(idPorta);
  474.                         }catch(Exception e){
  475.                             logCore.debug("Recupero dati soggetto fruitore (identificativoPorta) dal registro fallito: "+e.getMessage(),e);
  476.                         }
  477.                     }
  478.                     if(requestInfo.getRequestConfig().getSoggettoFruitoreSoggettoVirtuale()==null) {
  479.                         try{
  480.                             boolean soggettoVirtuale = configurazionePdDManager.isSoggettoVirtuale(idSoggettoFruitore, null); // passo null volutamente, per accedere alla configurazione
  481.                             requestInfo.getRequestConfig().setSoggettoFruitoreSoggettoVirtuale(soggettoVirtuale);
  482.                         }catch(Exception e){
  483.                             logCore.debug("Recupero dati soggetto fruitore (soggettoVirtuale) dal registro fallito: "+e.getMessage(),e);
  484.                         }
  485.                     }
  486.                     if(requestInfo.getRequestConfig().getSoggettoFruitorePddReaded()==null) {
  487.                         try{
  488.                             if(requestInfo.getRequestConfig().getSoggettoFruitoreRegistry()!=null) {
  489.                                 if(requestInfo.getRequestConfig().getSoggettoFruitoreRegistry().getPortaDominio()!=null &&
  490.                                         StringUtils.isNotEmpty(requestInfo.getRequestConfig().getSoggettoFruitoreRegistry().getPortaDominio())) {
  491.                                     PortaDominio pdd = registroServiziManager.getPortaDominio(requestInfo.getRequestConfig().getSoggettoFruitoreRegistry().getPortaDominio(), null, null); // passo null volutamente, per accedere alla configurazione
  492.                                     requestInfo.getRequestConfig().setSoggettoFruitorePddReaded(true);
  493.                                     requestInfo.getRequestConfig().setSoggettoFruitorePdd(pdd);
  494.                                 }
  495.                                 else {
  496.                                     requestInfo.getRequestConfig().setSoggettoFruitorePddReaded(true);
  497.                                 }
  498.                             }
  499.                         }catch(Exception e){
  500.                             logCore.debug("Recupero dati soggetto fruitore (pdd) dal registro fallito: "+e.getMessage(),e);
  501.                         }
  502.                     }
  503.                     if(requestInfo.getRequestConfig().getSoggettoFruitoreImplementazionePdd()==null) {
  504.                         try{
  505.                             String impl = registroServiziManager.getImplementazionePdD(idSoggettoFruitore, null, null); // passo null volutamente, per accedere alla configurazione
  506.                             requestInfo.getRequestConfig().setSoggettoFruitoreImplementazionePdd(impl);
  507.                         }catch(Exception e){
  508.                             logCore.debug("Recupero dati soggetto fruitore (implementazione pdd) dal registro fallito: "+e.getMessage(),e);
  509.                         }
  510.                     }
  511.                 }
  512.                 
  513.                 // updateInformazioniCooperazione
  514.                 requestInfo.setFruitore(idSoggettoFruitore);
  515.                 requestInfo.setIdServizio(idServizio);
  516.                 if(generatoreErrore!=null){
  517.                     generatoreErrore.updateInformazioniCooperazione(idSoggettoFruitore, idServizio);
  518.                 }
  519.                                 
  520.                 // Aggiorno service binding configuration rispetto al servizio localizzato
  521.                 try{
  522.                     bindingConfig = pf.createProtocolConfiguration().getServiceBindingConfiguration(protocolContext, integrationServiceBinding, idServizio, registryReader);
  523.                     requestInfo.setBindingConfig(bindingConfig);
  524.                 }catch(RegistryNotFound notFound){
  525.                     logCore.debug("Lettura Configurazione Servizio fallita (notFound): "+notFound.getMessage(),notFound);
  526.                     msgDiag.addKeywordErroreProcessamento(notFound);
  527.                     msgDiag.logPersonalizzato(MsgDiagnosticiProperties.MSG_DIAG_RICEZIONE_CONTENUTI_APPLICATIVI,"portaDelegataNonEsistente");
  528.                     return ConnectorDispatcherUtils.doError(requestInfo, generatoreErrore,
  529.                             ErroriIntegrazione.ERRORE_405_SERVIZIO_NON_TROVATO.getErroreIntegrazione(),
  530.                             IntegrationFunctionError.API_OUT_UNKNOWN, notFound, null, res, logCore, ConnectorDispatcherUtils.CLIENT_ERROR);
  531.                 }catch(Exception error){
  532.                     logCore.error("Lettura Configurazione Servizio fallita: "+error.getMessage(),error);
  533.                     msgDiag.addKeywordErroreProcessamento(error);
  534.                     msgDiag.logPersonalizzato(MsgDiagnosticiProperties.MSG_DIAG_RICEZIONE_CONTENUTI_APPLICATIVI,"portaDelegataNonEsistente");
  535.                     return ConnectorDispatcherUtils.doError(requestInfo, generatoreErrore,
  536.                             ErroriIntegrazione.ERRORE_5XX_GENERICO_PROCESSAMENTO_MESSAGGIO.get5XX_ErroreProcessamento("Lettura Configurazione Servizio fallita"),
  537.                             IntegrationFunctionError.INTERNAL_REQUEST_ERROR, error, null, res, logCore, ConnectorDispatcherUtils.GENERAL_ERROR);
  538.                 }
  539.                 
  540.                 // Verifico correttezza Content-Type
  541.                 String ct = null;
  542.                 try {
  543.                     ct = protocolContext.getContentType();
  544.                     if(ct!=null && !"".equals(ct)) {
  545.                         //new ContentType(ct).getBaseType();
  546.                         ContentTypeUtilities.validateContentType(ct);
  547.                     }
  548.                 }catch(Exception error){
  549.                     if(res!=null) {
  550.                         logCore.error("Lettura ContentType fallita: "+error.getMessage(),error);
  551.                         msgDiag.addKeywordErroreProcessamento(error);
  552.                         msgDiag.addKeyword(CostantiPdD.KEY_DETAILS, " Content-Type '"+ct+"' presente nella richiesta non valido;");
  553.                         msgDiag.logPersonalizzato(MsgDiagnosticiProperties.MSG_DIAG_RICEZIONE_CONTENUTI_APPLICATIVI,"richiestaNonValida");
  554.                         ConnectorDispatcherInfo cdiError = ConnectorDispatcherUtils.doError(requestInfo, generatoreErrore,
  555.                                 ErroriIntegrazione.ERRORE_432_PARSING_EXCEPTION_RICHIESTA.getErrore432_MessaggioRichiestaMalformato(error),
  556.                                 IntegrationFunctionError.BAD_REQUEST, error, null, res, logCore, ConnectorDispatcherUtils.CLIENT_ERROR);
  557.                         try {
  558.                             cdiError.setEsitoTransazione(pf.createEsitoBuilder().getEsito(requestInfo.getProtocolContext(),EsitoTransazioneName.CONTENUTO_RICHIESTA_NON_RICONOSCIUTO));
  559.                             if(pddContextNullable!=null) {
  560.                                 pddContextNullable.addObject(org.openspcoop2.core.constants.Costanti.CONTENUTO_RICHIESTA_NON_RICONOSCIUTO, true);
  561.                             }
  562.                         }catch(Throwable t) {
  563.                             // ignore
  564.                         }
  565.                         return cdiError;
  566.                     }
  567.                     return null;
  568.                 }
  569.                 
  570.                 // Aggiorno message type
  571.                 try{
  572.                     MessageType requestMessageTypeIntegration = bindingConfig.getRequestMessageType(integrationServiceBinding, 
  573.                             protocolContext, protocolContext.getContentType());
  574.                     requestInfo.setIntegrationRequestMessageType(requestMessageTypeIntegration);
  575.                     
  576.                     MessageType requestMessageTypeProtocol = bindingConfig.getRequestMessageType(protocolServiceBinding, 
  577.                             protocolContext, protocolContext.getContentType());
  578.                     requestInfo.setProtocolRequestMessageType(requestMessageTypeProtocol);
  579.                     
  580.                     if(generatoreErrore!=null) {
  581.                         generatoreErrore.updateRequestMessageType(requestMessageTypeIntegration);
  582.                     }
  583.                 }catch(Exception error){
  584.                     logCore.error("Identificazione MessageType fallita: "+error.getMessage(),error);
  585.                     msgDiag.addKeywordErroreProcessamento(error);
  586.                     msgDiag.logPersonalizzato(MsgDiagnosticiProperties.MSG_DIAG_RICEZIONE_CONTENUTI_APPLICATIVI,"portaDelegataNonEsistente");
  587.                     return ConnectorDispatcherUtils.doError(requestInfo, generatoreErrore,
  588.                             ErroriIntegrazione.ERRORE_5XX_GENERICO_PROCESSAMENTO_MESSAGGIO.get5XX_ErroreProcessamento("Identificazione MessageType fallita"),
  589.                             IntegrationFunctionError.INTERNAL_REQUEST_ERROR, error, null, res, logCore, ConnectorDispatcherUtils.GENERAL_ERROR);
  590.                 }
  591.                 
  592.                 // Controllo Service Binding rispetto alla url e al tipo di servizio
  593.                 if(requestInfo.getProtocolContext()!=null && bindingConfig.isServiceBindingContextEnabled(integrationServiceBinding, requestInfo.getProtocolContext().getProtocolWebContext())==false) {
  594.                     if(res!=null) {
  595.                         String url = requestInfo.getProtocolContext().getRequestURI();
  596.                         logCore.error("L'API invocata possiede un service binding '"+integrationServiceBinding+"' non abilitato sul contesto utilizzato: "+url);
  597.                         msgDiag.logErroreGenerico("L'API invocata possiede un service binding '"+integrationServiceBinding+"' non abilitato sul contesto utilizzato", "CheckServiceBinding");
  598.                         return ConnectorDispatcherUtils.doError(requestInfo, generatoreErrore, 
  599.                                 ErroriIntegrazione.ERRORE_447_API_NON_INVOCABILE_CONTESTO_UTILIZZATO.getErroreIntegrazione(),
  600.                                 IntegrationFunctionError.NOT_SUPPORTED_BY_PROTOCOL, null, null, res, logCore, ConnectorDispatcherUtils.CLIENT_ERROR);
  601.                     }
  602.                     return null;
  603.                 }
  604.                 if(bindingConfig.isServiceBindingServiceTypeEnabled(integrationServiceBinding, idServizio.getTipo())==false) {
  605.                     if(res!=null) {
  606.                         logCore.error("L'API invocata possiede un service binding '"+integrationServiceBinding+"' non abilitato per il tipo di servizio '"+idServizio.getTipo()+"'");
  607.                         msgDiag.logErroreGenerico("L'API invocata possiede un service binding '"+integrationServiceBinding+"' non abilitato per il tipo di servizio '"+idServizio.getTipo(), "CheckServiceBinding");
  608.                         return ConnectorDispatcherUtils.doError(requestInfo, generatoreErrore, 
  609.                                 ErroriIntegrazione.ERRORE_448_API_NON_INVOCABILE_TIPO_SERVIZIO_UTILIZZATO.getErroreIntegrazione(),
  610.                                 IntegrationFunctionError.NOT_SUPPORTED_BY_PROTOCOL, null, null, res, logCore, ConnectorDispatcherUtils.CLIENT_ERROR);
  611.                     }
  612.                     return null;
  613.                 }
  614.                 
  615.             }
  616.         }
  617.             
  618.             
  619.         if(requestInfo!=null && requestInfo.getProtocolServiceBinding()!=null && 
  620.                 ServiceBinding.SOAP.equals(requestInfo.getProtocolServiceBinding()) && 
  621.                 requestInfo.getProtocolContext()!=null &&
  622.                 HttpRequestMethod.OPTIONS.name().equalsIgnoreCase(requestInfo.getProtocolContext().getRequestType())) {
  623.             
  624.             // Gestione CORS
  625.             try{
  626.                 CorsConfigurazione cors = null;
  627.                 HttpServletRequest httpServletRequest = null;
  628.                 if(requestInfo!=null && requestInfo.getProtocolContext()!=null) {
  629.                     httpServletRequest = requestInfo.getProtocolContext().getHttpServletRequest();  
  630.                 }
  631.                 
  632.                 if(httpServletRequest!=null) {
  633.                     if(pdDefault!=null) {
  634.                         cors = configurazionePdDManager.getConfigurazioneCORS(pdDefault);
  635.                     }
  636.                     else {
  637.                         cors = configurazionePdDManager.getConfigurazioneCORS();
  638.                     }
  639.                 }
  640.                 else {
  641.                     cors = new CorsConfigurazione();
  642.                     cors.setStato(StatoFunzionalita.DISABILITATO);
  643.                 }
  644.                 
  645.                 if(StatoFunzionalita.ABILITATO.equals(cors.getStato())) {
  646.                     if(TipoGestioneCORS.GATEWAY.equals(cors.getTipo())) {
  647.                         
  648.                         /*
  649.                         
  650.                         org.openspcoop2.pdd.core.CORSFilter corsFilter = new org.openspcoop2.pdd.core.CORSFilter(logCore, cors);
  651.                         org.openspcoop2.pdd.core.CORSWrappedHttpServletResponse resCORS = new org.openspcoop2.pdd.core.CORSWrappedHttpServletResponse(false);
  652.                         corsFilter.doCORS(httpServletRequest, resCORS, org.openspcoop2.utils.transport.http.CORSRequestType.PRE_FLIGHT, true);
  653.                         org.openspcoop2.message.OpenSPCoop2Message msgCORSResponse = resCORS.buildMessage();
  654.                         org.openspcoop2.protocol.sdk.builder.EsitoTransazione esito = 
  655.                                 requestInfo.getProtocolFactory().createEsitoBuilder().getEsito(requestInfo.getProtocolContext(),
  656.                                         org.openspcoop2.protocol.sdk.constants.EsitoTransazioneName.CORS_PREFLIGHT_REQUEST_VIA_GATEWAY);
  657.                         ConnectorDispatcherInfo c = ConnectorDispatcherInfo.getGeneric(msgCORSResponse, 
  658.                                 resCORS.getStatus(), null, resCORS.getHeader(), esito);
  659.                         if(pddContextNullable!=null) {
  660.                             pddContextNullable.addObject(org.openspcoop2.core.constants.Costanti.CORS_PREFLIGHT_REQUEST_VIA_GATEWAY, "true");
  661.                         }
  662.                         ConnectorDispatcherUtils.doInfo(c, requestInfo, res, logCore, true);
  663.                         return c;
  664.                         
  665.                         */
  666.                         
  667.                         // Fix per avere il dump anche nelle comunicazioni soap, converto in REST
  668.                         requestInfo.setIntegrationServiceBinding(ServiceBinding.REST);
  669.                         requestInfo.setProtocolServiceBinding(ServiceBinding.REST);
  670.                         generatoreErrore.updateServiceBinding(ServiceBinding.REST);
  671.                         
  672.                         requestInfo.setIntegrationRequestMessageType(MessageType.BINARY);
  673.                         requestInfo.setProtocolRequestMessageType(MessageType.BINARY);
  674.                         generatoreErrore.updateRequestMessageType(MessageType.BINARY);
  675.                         
  676.                         if(pddContextNullable!=null) {
  677.                             pddContextNullable.addObject(CostantiPdD.CORS_PREFLIGHT_REQUEST_SOAP, "true");
  678.                         }
  679.                         
  680.                     }
  681.                     else {
  682.                         
  683.                         if(pddContextNullable!=null) {
  684.                             pddContextNullable.addObject(org.openspcoop2.core.constants.Costanti.CORS_PREFLIGHT_REQUEST_TRASPARENTE, "true");
  685.                         }
  686.                         
  687.                         requestInfo.setIntegrationServiceBinding(ServiceBinding.REST);
  688.                         requestInfo.setProtocolServiceBinding(ServiceBinding.REST);
  689.                         generatoreErrore.updateServiceBinding(ServiceBinding.REST);
  690.                         
  691.                         requestInfo.setIntegrationRequestMessageType(MessageType.BINARY);
  692.                         requestInfo.setProtocolRequestMessageType(MessageType.BINARY);
  693.                         generatoreErrore.updateRequestMessageType(MessageType.BINARY);
  694.                     }
  695.                 }
  696.                 
  697.             }catch(Exception error){
  698.                 
  699.                 if(res!=null) {
  700.                     logCore.error("Gestione CORS fallita: "+error.getMessage(),error);
  701.                     msgDiag.addKeywordErroreProcessamento(error);
  702.                     msgDiag.logPersonalizzato(MsgDiagnosticiProperties.MSG_DIAG_RICEZIONE_CONTENUTI_APPLICATIVI,"portaDelegataNonEsistente");
  703.                     return ConnectorDispatcherUtils.doError(requestInfo, generatoreErrore,
  704.                             ErroriIntegrazione.ERRORE_5XX_GENERICO_PROCESSAMENTO_MESSAGGIO.get5XX_ErroreProcessamento("Gestione CORS fallita"),
  705.                             IntegrationFunctionError.INTERNAL_REQUEST_ERROR, error, null, res, logCore, ConnectorDispatcherUtils.GENERAL_ERROR);
  706.                 }
  707.                 return null;
  708.                 
  709.             }
  710.         }
  711.         
  712.         
  713.         return null;
  714.     }
  715.     
  716.     public static void emitTransaction(Logger logCore, ConnectorInMessage req, PdDContext pddContext, Date dataAccettazioneRichiesta,
  717.             ConnectorDispatcherInfo info) {
  718.         emitTransaction(null, logCore, req, pddContext, dataAccettazioneRichiesta, info);
  719.     }
  720.     public static void emitTransaction(RicezioneContenutiApplicativiContext context,Logger logCore, ConnectorInMessage req, PdDContext pddContext, Date dataAccettazioneRichiesta,
  721.             ConnectorDispatcherInfo info) {
  722.         try {
  723.             if (!OpenSPCoop2Startup.initialize || OpenSPCoop2Properties.getInstance() == null) {
  724.                 logCore.error("emitTransaction, registrazione non effettuata: inizializzazione govway non rilevata");
  725.                 return;
  726.             }
  727.             
  728.             String idModulo = req.getIdModulo();
  729.             IDService idModuloAsService = req.getIdModuloAsIDService();
  730.             IProtocolFactory<?> protocolFactory = req.getProtocolFactory();
  731.             RequestInfo requestInfo = req.getRequestInfo();
  732.             
  733.             if(context!=null && context.getPddContext()!=null) {
  734.                 PreInRequestHandler.readClientAddress(logCore, req, context.getPddContext());
  735.                 if(OpenSPCoop2Properties.getInstance().isTransazioniEnabled()) {
  736.                     try {
  737.                         String idTransazione = (String) context.getPddContext().getObject(org.openspcoop2.core.constants.Costanti.ID_TRANSAZIONE);
  738.                         if(idTransazione!=null) {
  739.                             Transaction tr = TransactionContext.getTransaction(idTransazione);
  740.                             PreInRequestHandler.setInfoInvocation(tr, requestInfo, req);
  741.                         }
  742.                     }catch(Throwable e){
  743.                         logCore.error("postOutResponse, lettura parametri fallita: "+e.getMessage(),e);
  744.                     }
  745.                 }
  746.             }
  747.             
  748.             emitTransaction(context,logCore, idModulo, idModuloAsService, protocolFactory, requestInfo, pddContext, dataAccettazioneRichiesta, info);
  749.         }catch(Throwable e){
  750.             logCore.error("postOutResponse, registrazione fallita: "+e.getMessage(),e);
  751.         }
  752.     }
  753.     
  754.     public static void emitTransaction(RicezioneContenutiApplicativiContext context,Logger logCore,String idModulo,IDService idModuloAsService, IProtocolFactory<?> protocolFactory, RequestInfo requestInfo,
  755.             PdDContext pddContext, Date dataAccettazioneRichiesta,
  756.             ConnectorDispatcherInfo info) {
  757.         
  758.         try {
  759.             if (!OpenSPCoop2Startup.initialize || OpenSPCoop2Properties.getInstance() == null) {
  760.                 logCore.error("postOutResponse, registrazione non effettuata: inizializzazione govway non rilevata");
  761.                 return;
  762.             }
  763.         
  764.             if(context==null) {
  765.                 context = new RicezioneContenutiApplicativiContext(idModuloAsService,dataAccettazioneRichiesta,requestInfo);
  766.             }
  767.             
  768.             PostOutResponseContext postOutResponseContext = new PostOutResponseContext(logCore,protocolFactory);
  769.             postOutResponseContext.setTipoPorta(TipoPdD.DELEGATA);
  770.             postOutResponseContext.setIdModulo(idModulo);
  771.             
  772.             postOutResponseContext.setPddContext(pddContext);
  773.             if(pddContext==null) {
  774.                 postOutResponseContext.setPddContext(context.getPddContext());
  775.             }
  776.             else {
  777.                 pddContext.addAll(context.getPddContext(), true);
  778.             }
  779.             postOutResponseContext.getPddContext().addObject(CostantiPdD.DATA_ACCETTAZIONE_RICHIESTA, dataAccettazioneRichiesta);

  781.             if(OpenSPCoop2Properties.getInstance().isTransazioniEnabled()) {
  782.                 // NOTA: se gia' esiste con l'id di transazione, non viene ricreata
  783.                 TransactionContext.createTransaction((String)postOutResponseContext.getPddContext().getObject(org.openspcoop2.core.constants.Costanti.ID_TRANSAZIONE), "RicezioneContenutiApplicativi.3");
  784.             }
  785.             
  786.             postOutResponseContext.setDataElaborazioneMessaggio(DateManager.getDate());
  787.             postOutResponseContext.setEsito(info.getEsitoTransazione());
  788.             postOutResponseContext.setReturnCode(info.getStatus());
  789.             postOutResponseContext.setResponseHeaders(info.getTrasporto());
  790.             if(info.getContentType()!=null) {
  791.                 if(postOutResponseContext.getResponseHeaders()==null) {
  792.                     postOutResponseContext.setResponseHeaders(new HashMap<>());
  793.                 }
  794.                 TransportUtils.setHeader(postOutResponseContext.getResponseHeaders(),HttpConstants.CONTENT_TYPE, info.getContentType());
  795.             }
  796.                     
  797.             if(info.getMessage()!=null){
  798.                 
  799.                 postOutResponseContext.setOutputResponseMessageSize(info.getMessage().getOutgoingMessageContentLength());
  800.                 
  801.                 postOutResponseContext.setMessaggio(info.getMessage());
  802.             }
  803.     
  804.             MsgDiagnostico msgDiag = MsgDiagnostico.newInstance(TipoPdD.DELEGATA,idModulo);
  805.             msgDiag.setPrefixMsgPersonalizzati(MsgDiagnosticiProperties.MSG_DIAG_RICEZIONE_CONTENUTI_APPLICATIVI);
  806.             
  807.             GestoreHandlers.postOutResponse(postOutResponseContext, msgDiag, logCore);
  808.             
  809.         }catch(Throwable e){
  810.             logCore.error("postOutResponse, registrazione fallita: "+e.getMessage(),e);
  811.         }
  812.     
  813.     }
  814. }
Created with JaCoCo 0.8.8.202204050719