SDIProtocolManager.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.  */


  22. package org.openspcoop2.protocol.sdi.config;

  24. import java.util.Map;

  26. import org.slf4j.Logger;
  27. import org.openspcoop2.message.OpenSPCoop2Message;
  28. import org.openspcoop2.message.OpenSPCoop2MessageFactory;
  29. import org.openspcoop2.message.constants.MessageRole;
  30. import org.openspcoop2.message.constants.MessageType;
  31. import org.openspcoop2.protocol.basic.config.BasicManager;
  32. import org.openspcoop2.protocol.sdi.constants.SDICostanti;
  33. import org.openspcoop2.protocol.sdi.constants.SDICostantiServizioRiceviFile;
  34. import org.openspcoop2.protocol.sdi.constants.SDICostantiServizioRiceviNotifica;
  35. import org.openspcoop2.protocol.sdi.constants.SDICostantiServizioRicezioneFatture;
  36. import org.openspcoop2.protocol.sdi.constants.SDICostantiServizioTrasmissioneFatture;
  37. import org.openspcoop2.protocol.sdk.Busta;
  38. import org.openspcoop2.protocol.sdk.IProtocolFactory;
  39. import org.openspcoop2.protocol.sdk.ProtocolException;
  40. import org.openspcoop2.protocol.sdk.constants.FaultIntegrationGenericInfoMode;
  41. import org.openspcoop2.protocol.sdk.constants.TipoIntegrazione;
  42. import org.openspcoop2.protocol.sdk.registry.IRegistryReader;
  43. import org.openspcoop2.utils.BooleanNullable;
  44. import org.openspcoop2.utils.io.notifier.NotifierInputStreamParams;
  45. import org.openspcoop2.utils.transport.TransportRequestContext;
  46. import org.openspcoop2.utils.transport.TransportResponseContext;

  48. /**
  49.  * Classe che implementa, in base al protocollo SdI, l'interfaccia {@link org.openspcoop2.protocol.sdk.config.IProtocolManager} 
  50.  *
  51.  * @author Poli Andrea (apoli@link.it)
  52.  * @author $Author$
  53.  * @version $Rev$, $Date$
  54.  */
  55. public class SDIProtocolManager extends BasicManager {
  56.     


  59.     protected SDIProperties sdiProperties = null;
  60.     protected Logger logger = null;
  61.     public SDIProtocolManager(IProtocolFactory<?> protocolFactory) throws ProtocolException{
  62.         super(protocolFactory);
  63.         this.logger = this.getProtocolFactory().getLogger();
  64.         this.sdiProperties = SDIProperties.getInstance(this.logger);
  65.     }
  66.     
  67.     
  68.     /* *********** VALIDAZIONE/GENERAZIONE BUSTE ******************* */
  69.     
  70.     @Override
  71.     public boolean isIgnoraEccezioniNonGravi(){
  72.         return true;
  73.     }
  74.     
  75.     @Override
  76.     public boolean isGenerazioneListaEccezioniErroreProcessamento(){
  77.         return true; // l'eccezione viene utilizzata per produrre un errore applicativo e/o per impostare un codice nel soap fault
  78.     }
  79.     
  80.     
  81.     
  82.     
  83.     
  84.     /* *********** Fault della Porta (Protocollo, Porta Applicativa) ******************* */
  85.     
  86.     @Override
  87.     public boolean isGenerazioneDetailsFaultProtocollo_EccezioneValidazione(){
  88.         return this.sdiProperties.isGenerazioneDetailsSOAPFaultProtocolValidazione();
  89.     }
  90.     
  91.     @Override
  92.     public boolean isGenerazioneDetailsFaultProtocollo_EccezioneProcessamento(){
  93.         return this.sdiProperties.isGenerazioneDetailsSOAPFaultProtocolProcessamento();
  94.     }
  95.         
  96.     @Override
  97.     public boolean isGenerazioneDetailsFaultProtocolloConStackTrace(){
  98.         return this.sdiProperties.isGenerazioneDetailsSOAPFaultProtocolWithStackTrace();
  99.     }
  100.     
  101.     @Override
  102.     public boolean isGenerazioneDetailsFaultProtocolloConInformazioniGeneriche(){
  103.         return this.sdiProperties.isGenerazioneDetailsSOAPFaultProtocolConInformazioniGeneriche();
  104.     }
  105.     
  106.     
  107.     
  108.     /* *********** Fault della Porta (Integrazione, Porta Delegata) ******************* */
  109.     
  110.     @Override
  111.     public boolean isGenerazioneDetailsFaultIntegratione_erroreServer(){
  112.         return this.sdiProperties.isGenerazioneDetailsSOAPFaultIntegrationServerError();
  113.     }
  114.     
  115.     @Override
  116.     public boolean isGenerazioneDetailsFaultIntegratione_erroreClient(){
  117.         return this.sdiProperties.isGenerazioneDetailsSOAPFaultIntegrationClientError();
  118.     }
  119.     
  120.     @Override
  121.     public boolean isGenerazioneDetailsFaultIntegrationeConStackTrace(){
  122.         return this.sdiProperties.isGenerazioneDetailsSOAPFaultIntegrationWithStackTrace();
  123.     }
  124.     
  125.     @Override
  126.     public FaultIntegrationGenericInfoMode getModalitaGenerazioneInformazioniGeneriche_DetailsFaultIntegrazione(){
  127.         Boolean value = this.sdiProperties.isGenerazioneDetailsSOAPFaultIntegrazionConInformazioniGeneriche();
  128.         if(value==null){
  129.             return FaultIntegrationGenericInfoMode.SERVIZIO_APPLICATIVO;
  130.         }
  131.         else if(value){
  132.             return FaultIntegrationGenericInfoMode.ABILITATO;
  133.         }else{
  134.             return FaultIntegrationGenericInfoMode.DISABILITATO;
  135.         }
  136.     }
  137.     
  138.     
  139.     
  140.     /* *********** Fault della Porta (Generati dagli attori esterni) ******************* */
  141.     
  142.     @Override
  143.     public BooleanNullable isAggiungiDetailErroreApplicativo_FaultApplicativo() {
  144.         return this.sdiProperties.isAggiungiDetailErroreApplicativo_SoapFaultApplicativo();
  145.     }

  147.     @Override
  148.     public BooleanNullable isAggiungiDetailErroreApplicativo_FaultPdD() {
  149.         return this.sdiProperties.isAggiungiDetailErroreApplicativo_SoapFaultPdD();
  150.     }
  151.     
  152.     
  153.     
  154.     
  155.     
  156.     
  157.     /* *********** INTEGRAZIONE ******************* */
  158.     
  159.     @Override
  160.     public Map<String, String> buildIntegrationProperties(Busta busta,
  161.             boolean isRichiesta, TipoIntegrazione tipoIntegrazione)
  162.             throws ProtocolException {
  163.         
  164.         if(busta==null){
  165.             return null;
  166.         }
  167.         
  168.         boolean buildInfo = false;
  169.         
  170.         if(busta!=null && busta.sizeProperties()>0){
  171.             busta.removeProperty(SDICostanti.SDI_BUSTA_EXT_ESITO_COMMITTENTE);
  172.             busta.removeProperty(SDICostanti.SDI_BUSTA_EXT_ERRORI);
  173.         }
  174.         
  175.         if(isRichiesta){
  176.             
  177.             // Servizio
  178.             if(SDICostantiServizioTrasmissioneFatture.TRASMISSIONE_SERVIZIO_TRASMISSIONE_FATTURE.equals(busta.getServizio())){
  179.                 if(SDICostantiServizioTrasmissioneFatture.TRASMISSIONE_SERVIZIO_TRASMISSIONE_FATTURE_AZIONE_RICEVUTA_CONSEGNA.equals(busta.getAzione())){
  180.                     buildInfo = true;
  181.                 }
  182.                 else if(SDICostantiServizioTrasmissioneFatture.TRASMISSIONE_SERVIZIO_TRASMISSIONE_FATTURE_AZIONE_NOTIFICA_MANCATA_CONSEGNA.equals(busta.getAzione())){
  183.                     buildInfo = true;
  184.                 }
  185.                 else if(SDICostantiServizioTrasmissioneFatture.TRASMISSIONE_SERVIZIO_TRASMISSIONE_FATTURE_AZIONE_NOTIFICA_SCARTO.equals(busta.getAzione())){
  186.                     buildInfo = true;
  187.                 }
  188.                 else if(SDICostantiServizioTrasmissioneFatture.TRASMISSIONE_SERVIZIO_TRASMISSIONE_FATTURE_AZIONE_NOTIFICA_ESITO.equals(busta.getAzione())){
  189.                     buildInfo = true;
  190.                 }
  191.                 else if(SDICostantiServizioTrasmissioneFatture.TRASMISSIONE_SERVIZIO_TRASMISSIONE_FATTURE_AZIONE_NOTIFICA_DECORRENZA_TERMINI.equals(busta.getAzione())){
  192.                     buildInfo = true;
  193.                 }
  194.                 else if(SDICostantiServizioTrasmissioneFatture.TRASMISSIONE_SERVIZIO_TRASMISSIONE_FATTURE_AZIONE_ATTESTAZIONE_TRASMISSIONE_FATTURA.equals(busta.getAzione())){
  195.                     buildInfo = true;
  196.                 }
  197.                 else{
  198.                     throw new ProtocolException("Servizio["+busta.getServizio()+"] con Azione["+busta.getAzione()+"] non gestita dal protocollo durante la fase di richiesta");
  199.                 }
  200.             }
  201.             else if(SDICostantiServizioRicezioneFatture.RICEZIONE_SERVIZIO_RICEZIONE_FATTURE.equals(busta.getServizio())){
  202.                 if(SDICostantiServizioRicezioneFatture.RICEZIONE_SERVIZIO_RICEZIONE_FATTURE_AZIONE_RICEVI_FATTURE.equals(busta.getAzione())){
  203.                     buildInfo = true;
  204.                 }
  205.                 else if(SDICostantiServizioRicezioneFatture.RICEZIONE_SERVIZIO_RICEZIONE_FATTURE_AZIONE_NOTIFICA_DECORRENZA_TERMINI.equals(busta.getAzione())){
  206.                     buildInfo = true;
  207.                 }
  208.                 else{
  209.                     throw new ProtocolException("Servizio["+busta.getServizio()+"] con Azione["+busta.getAzione()+"] non gestita dal protocollo durante la fase di richiesta");
  210.                 }
  211.             }
  212.             else if(SDICostantiServizioRiceviFile.SDI_SERVIZIO_RICEVI_FILE.equals(busta.getServizio())){
  213.                 buildInfo = false;
  214.             }
  215.             else if(SDICostantiServizioRiceviNotifica.SDI_SERVIZIO_RICEVI_NOTIFICA.equals(busta.getServizio())){
  216.                 buildInfo = false;
  217.             }
  218.             else{
  219.                 boolean whiteList = false;
  220.                 if(busta.getServizio()!=null && this.sdiProperties.getServiziWhiteList().contains(busta.getServizio())){
  221.                     if(busta.getAzione()!=null && this.sdiProperties.getAzioniWhiteList().contains(busta.getAzione())){
  222.                         this.logger.debug("Servizio ["+busta.getServizio()+"] e Azione ["+busta.getAzione()+"] in white list");
  223.                         whiteList = true;
  224.                     }
  225.                 }
  226.                 if(!whiteList){
  227.                     throw new ProtocolException("Servizio["+busta.getServizio()+"] non gestite dal protocollo durante la fase di richiesta");
  228.                 }
  229.             }
  230.             
  231.         }
  232.         else{

  234.             // Servizio
  235.             if(SDICostantiServizioRiceviFile.SDI_SERVIZIO_RICEVI_FILE.equals(busta.getServizio())
  236.                     && SDICostantiServizioRiceviFile.SDI_SERVIZIO_RICEVI_FILE_AZIONE_RICEVI_FILE.equals(busta.getAzione())){
  237.                 buildInfo = true;
  238.             }
  239.             else if(SDICostantiServizioRiceviNotifica.SDI_SERVIZIO_RICEVI_NOTIFICA.equals(busta.getServizio())
  240.                     && SDICostantiServizioRiceviNotifica.SDI_SERVIZIO_NOTIFICA_ESITO_AZIONE_NOTIFICA_ESITO.equals(busta.getAzione())){
  241.                 buildInfo = true;
  242.             }
  243.             else if(SDICostantiServizioTrasmissioneFatture.TRASMISSIONE_SERVIZIO_TRASMISSIONE_FATTURE.equals(busta.getServizio())){
  244.                 buildInfo = false;
  245.             }
  246.             else if(SDICostantiServizioRicezioneFatture.RICEZIONE_SERVIZIO_RICEZIONE_FATTURE.equals(busta.getServizio())){
  247.                 buildInfo = false;
  248.             }
  249.             else{
  250.                 boolean whiteList = false;
  251.                 if(busta.getServizio()!=null && this.sdiProperties.getServiziWhiteList().contains(busta.getServizio())){
  252.                     if(busta.getAzione()!=null && this.sdiProperties.getAzioniWhiteList().contains(busta.getAzione())){
  253.                         this.logger.debug("Servizio ["+busta.getServizio()+"] e Azione ["+busta.getAzione()+"] in white list");
  254.                         whiteList = true;
  255.                     }
  256.                 }
  257.                 if(!whiteList){
  258.                     throw new ProtocolException("Servizio["+busta.getServizio()+"] e Azione["+busta.getAzione()+"] non gestite dal protocollo durante la fase di risposta");
  259.                 }
  260.             }
  261.             
  262.         }
  263.         
  264.         if(buildInfo){
  265.             return super.buildIntegrationProperties(busta, isRichiesta, tipoIntegrazione);
  266.         }
  267.         else{
  268.             return null;
  269.         }
  270.     }
  271.     
  272.     @Override
  273.     public OpenSPCoop2Message updateOpenSPCoop2MessageResponse(OpenSPCoop2Message msg, Busta busta, 
  274.             NotifierInputStreamParams notifierInputStreamParams, 
  275.             TransportRequestContext transportRequestContext, TransportResponseContext transportResponseContext,
  276.             IRegistryReader registryReader,
  277.             boolean integration) throws ProtocolException{
  278.                 
  279.         if(SDICostantiServizioRicezioneFatture.RICEZIONE_SERVIZIO_RICEZIONE_FATTURE.equals(busta.getServizio())){
  280.             if(SDICostantiServizioRicezioneFatture.RICEZIONE_SERVIZIO_RICEZIONE_FATTURE_AZIONE_RICEVI_FATTURE.equals(busta.getAzione())){
  281.                 if(transportResponseContext==null || transportResponseContext.getErrore()==null){
  282.                     // creo un nuovo messaggio, l'imbustamento si occupera' di creare la struttura
  283.                     OpenSPCoop2MessageFactory messageFactory = msg!=null ? msg.getFactory() : OpenSPCoop2MessageFactory.getDefaultMessageFactory();
  284.                     OpenSPCoop2Message msgR = messageFactory.createEmptyMessage(MessageType.SOAP_11,MessageRole.RESPONSE,notifierInputStreamParams);
  285.                     msgR.setTransportRequestContext(transportRequestContext);
  286.                     msgR.setTransportResponseContext(transportResponseContext);
  287.                     return msgR;
  288.                 }
  289.             }
  290.         }
  291.         
  292.         return super.updateOpenSPCoop2MessageResponse(msg, busta, 
  293.                 notifierInputStreamParams,transportRequestContext,transportResponseContext,registryReader,integration);
  294.     }
  295.     
  296.     
  297.     
  298.     
  299.     
  300.     /* *********** ALTRO ******************* */
  301.     
  302.     @Override
  303.     public Integer getHttpReturnCodeEmptyResponseOneWay(){
  304.         return 202;
  305.     }
  306.     
  307. }
Created with JaCoCo 0.8.8.202204050719