DumpRaw.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.connettori;

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

  27. import org.openspcoop2.core.config.DumpConfigurazione;
  28. import org.openspcoop2.core.config.constants.StatoFunzionalita;
  29. import org.openspcoop2.core.constants.TipoPdD;
  30. import org.openspcoop2.core.id.IDPortaApplicativa;
  31. import org.openspcoop2.core.id.IDSoggetto;
  32. import org.openspcoop2.core.transazioni.TransazioneApplicativoServer;
  33. import org.openspcoop2.message.constants.MessageType;
  34. import org.openspcoop2.pdd.config.OpenSPCoop2Properties;
  35. import org.openspcoop2.pdd.core.PdDContext;
  36. import org.openspcoop2.pdd.logger.Dump;
  37. import org.openspcoop2.pdd.services.connector.ConnectorException;
  38. import org.openspcoop2.protocol.sdk.dump.DumpException;
  39. import org.openspcoop2.utils.io.DumpByteArrayOutputStream;

  41. /**
  42.  * DumpRaw
  43.  * 
  44.  * @author Poli Andrea (apoli@link.it)
  45.  * @author $Author$
  46.  * @version $Rev$, $Date$
  47.  */
  48. public class DumpRaw {

  50.     @SuppressWarnings("unused")
  51.     private ConnettoreLogger logger;
  52.     @SuppressWarnings("unused")
  53.     private boolean pd;
  54.     private Dump dump;
  55.     private boolean dumpBinario;
  56.     private boolean dumpBinario_registrazioneDatabase = false;
  57.     private DumpConfigurazione dumpDatabaseConfigurazione;
  58.     private boolean dumpDatabaseRichiestaUscitaHeaders;
  59.     private boolean dumpDatabaseRichiestaUscitaPayload;
  60.     private boolean dumpDatabaseRispostaIngressoHeaders;
  61.     private boolean dumpDatabaseRispostaIngressoPayload;
  62.     private boolean onlyLogFileTraceRichiestaUscitaHeaders = false;
  63.     private boolean onlyLogFileTraceRichiestaUscitaPayload = false;
  64.     private boolean onlyLogFileTraceRispostaIngressoHeaders = false;
  65.     private boolean onlyLogFileTraceRispostaIngressoPayload = false;
  66.     
  67.     private IDSoggetto dominio;
  68.     private String modulo;
  69.     private TipoPdD tipoPdD;
  70.     
  71.     public DumpRaw(ConnettoreLogger log,IDSoggetto dominio,String modulo,TipoPdD tipoPdD, 
  72.             boolean dumpBinario, 
  73.             DumpConfigurazione dumpConfigurazione,
  74.             boolean fileTraceHeaders, boolean fileTracePayload) throws ConnectorException{
  75.         this.logger = log;
  76.         
  77.         switch (tipoPdD) {
  78.         case DELEGATA:
  79.             this.pd = true;
  80.             break;
  81.         default:
  82.             this.pd = false;
  83.             break;
  84.         }
  85.         
  86.         this.dumpBinario = dumpBinario;
  87.         if(this.dumpBinario) {
  88.             this.dumpBinario_registrazioneDatabase = OpenSPCoop2Properties.getInstance().isDumpBinarioRegistrazioneDatabase();
  89.         }
  90.         
  91.         if(dumpConfigurazione!=null) {
  92.             if(dumpConfigurazione.getRichiestaUscita()!=null) {
  93.                 // il parsing deve essere gestito con l'altra modalità, che dovrà gestire anche gli header, senno sul db si troveranno 2 messaggi
  94.                 boolean payloadParsing = StatoFunzionalita.ABILITATO.equals(dumpConfigurazione.getRichiestaUscita().getPayload()) &&
  95.                         StatoFunzionalita.ABILITATO.equals(dumpConfigurazione.getRichiestaUscita().getPayloadParsing());
  96.                 if(!payloadParsing) {
  97.                     if(StatoFunzionalita.ABILITATO.equals(dumpConfigurazione.getRichiestaUscita().getHeaders())){
  98.                         this.dumpDatabaseRichiestaUscitaHeaders = true;
  99.                     }
  100.                     if(StatoFunzionalita.ABILITATO.equals(dumpConfigurazione.getRichiestaUscita().getPayload())){
  101.                         this.dumpDatabaseRichiestaUscitaPayload = true;
  102.                     }
  103.                 }
  104.             }
  105.             if(dumpConfigurazione.getRispostaIngresso()!=null) {
  106.                 // il parsing deve essere gestito con l'altra modalità, che dovrà gestire anche gli header, senno sul db si troveranno 2 messaggi
  107.                 boolean payloadParsing = StatoFunzionalita.ABILITATO.equals(dumpConfigurazione.getRispostaIngresso().getPayload()) &&
  108.                         StatoFunzionalita.ABILITATO.equals(dumpConfigurazione.getRispostaIngresso().getPayloadParsing());
  109.                 if(!payloadParsing) {
  110.                     if(StatoFunzionalita.ABILITATO.equals(dumpConfigurazione.getRispostaIngresso().getHeaders())){
  111.                         this.dumpDatabaseRispostaIngressoHeaders = true;
  112.                     }
  113.                     if(StatoFunzionalita.ABILITATO.equals(dumpConfigurazione.getRispostaIngresso().getPayload())){
  114.                         this.dumpDatabaseRispostaIngressoPayload = true;
  115.                     }
  116.                 }
  117.             }
  118.             this.dumpDatabaseConfigurazione = dumpConfigurazione;
  119.         }
  120.         
  121.         if(!this.dumpDatabaseRichiestaUscitaHeaders && (!dumpBinario || !this.dumpBinario_registrazioneDatabase) ) {
  122.             this.onlyLogFileTraceRichiestaUscitaHeaders = fileTraceHeaders;
  123.         }
  124.         if(!this.dumpDatabaseRichiestaUscitaPayload && (!dumpBinario || !this.dumpBinario_registrazioneDatabase) ) {
  125.             this.onlyLogFileTraceRichiestaUscitaPayload = fileTracePayload;
  126.         }
  127.         if(!this.dumpDatabaseRispostaIngressoHeaders && (!dumpBinario || !this.dumpBinario_registrazioneDatabase) ) {
  128.             this.onlyLogFileTraceRispostaIngressoHeaders = fileTraceHeaders;
  129.         }
  130.         if(!this.dumpDatabaseRispostaIngressoPayload && (!dumpBinario || !this.dumpBinario_registrazioneDatabase) ) {
  131.             this.onlyLogFileTraceRispostaIngressoPayload = fileTracePayload;
  132.         }
  133.                 
  134.         this.dominio = dominio;
  135.         this.modulo = modulo;
  136.         this.tipoPdD = tipoPdD;
  137.     }
  138.     
  139.     public boolean isActiveDumpDatabase() {
  140.         return this.isDumpBinarioRegistrazioneDatabase() || isRegistrazioneDatabase() || onlyLogFileTrace();
  141.     }
  142.     public boolean isActiveDumpDatabaseRichiesta() {
  143.         return this.dumpBinario || isRegistrazioneDatabaseRichiesta() || onlyLogFileTraceRichiesta();
  144.     }
  145.     public boolean isActiveDumpDatabaseRisposta() {
  146.         return this.dumpBinario || isRegistrazioneDatabaseRisposta() || onlyLogFileTraceRisposta();
  147.     }
  148.     
  149.     private boolean isRegistrazioneDatabase() {
  150.         return this.isRegistrazioneDatabaseRichiesta()
  151.                 ||
  152.                this.isRegistrazioneDatabaseRisposta()
  153.                ;
  154.     }
  155.     private boolean isRegistrazioneDatabaseRichiesta() {
  156.         return this.dumpDatabaseRichiestaUscitaHeaders
  157.                 ||
  158.                this.dumpDatabaseRichiestaUscitaPayload
  159.                ;
  160.     }
  161.     private boolean isRegistrazioneDatabaseRisposta() {
  162.         return this.dumpDatabaseRispostaIngressoHeaders
  163.                 ||
  164.                this.dumpDatabaseRispostaIngressoPayload
  165.                ;
  166.     }
  167.     
  168.     private boolean onlyLogFileTrace() {
  169.         return this.onlyLogFileTraceRichiesta()
  170.                 ||
  171.                this.onlyLogFileTraceRisposta()
  172.                ;
  173.     }
  174.     private boolean onlyLogFileTraceRichiesta() {
  175.         return this.onlyLogFileTraceRichiestaUscitaHeaders
  176.                 ||
  177.                this.onlyLogFileTraceRichiestaUscitaPayload
  178.                 ||
  179.                this.onlyLogFileTraceRispostaIngressoHeaders
  180.                 ||
  181.                this.onlyLogFileTraceRispostaIngressoPayload
  182.                ;
  183.     }
  184.     private boolean onlyLogFileTraceRisposta() {
  185.         return this.onlyLogFileTraceRichiestaUscitaHeaders
  186.                 ||
  187.                this.onlyLogFileTraceRichiestaUscitaPayload
  188.                 ||
  189.                this.onlyLogFileTraceRispostaIngressoHeaders
  190.                 ||
  191.                this.onlyLogFileTraceRispostaIngressoPayload
  192.                ;
  193.     }
  194.     
  195.     private boolean isDumpBinarioRegistrazioneDatabase() {
  196.         return this.dumpBinario && this.dumpBinario_registrazioneDatabase;
  197.     }
  198.     
  199.     public void initDump(String interfaceName, PdDContext pddContext) throws DumpException {
  200.         initDump(interfaceName, pddContext, 
  201.                 null,
  202.                 null, null);
  203.     }
  204.     public void initDump(String interfaceName, PdDContext pddContext, 
  205.             TransazioneApplicativoServer transazioneApplicativoServer,
  206.             IDPortaApplicativa idPA, Date dataConsegnaTransazioneApplicativoServer) throws DumpException {
  207.         
  208.         if(!isActiveDumpDatabase()) {
  209.             return;
  210.         }
  211.         
  212.         if(this.isRegistrazioneDatabase() || this.isDumpBinarioRegistrazioneDatabase() || this.onlyLogFileTrace()) {
  213.             this.dump = new Dump(this.dominio, this.modulo, this.tipoPdD, interfaceName, pddContext, this.dumpDatabaseConfigurazione);
  214.             if(transazioneApplicativoServer!=null) {
  215.                 this.dump.setTransazioneApplicativoServer(transazioneApplicativoServer, 
  216.                         idPA, dataConsegnaTransazioneApplicativoServer);
  217.             }
  218.         }   
  219.     }
  220.         
  221.     public void emitDiagnosticStartDumpBinarioRichiestaUscita() {
  222.         if(!isActiveDumpDatabaseRichiesta()) {
  223.             return;
  224.         }
  225.         
  226.         if(this.dump!=null) {
  227.             boolean onlyFileTrace = !isRegistrazioneDatabaseRichiesta();
  228.             this.dump.emitDiagnosticStartDumpBinarioRichiestaUscita(onlyFileTrace);
  229.         }
  230.     }
  231.     public void dumpRequest(DumpByteArrayOutputStream content, MessageType messageType, InfoConnettoreUscita infoConnettoreUscita) throws DumpException {
  232.         
  233.         if(!isActiveDumpDatabaseRichiesta()) {
  234.             return;
  235.         }
  236.         
  237.         if(this.dump!=null) {
  238.             //if(content!=null){ // devono essere registrati anche solamente gli header
  239.             this.dump.dumpBinarioRichiestaUscita(this.isDumpBinarioRegistrazioneDatabase(), this.onlyLogFileTraceRichiestaUscitaHeaders, this.onlyLogFileTraceRichiestaUscitaPayload, 
  240.                     content, messageType,
  241.                     infoConnettoreUscita);
  242.             //}
  243.         }
  244.     }
  245.     
  246.     public void emitDiagnosticStartDumpBinarioRispostaIngresso() {
  247.         if(!isActiveDumpDatabaseRisposta()) {
  248.             return;
  249.         }
  250.         
  251.         if(this.dump!=null) {
  252.             boolean onlyFileTrace = !isRegistrazioneDatabaseRisposta();
  253.             this.dump.emitDiagnosticStartDumpBinarioRispostaIngresso(onlyFileTrace);
  254.         }
  255.     }
  256.     public void dumpResponse(DumpByteArrayOutputStream content, MessageType messageType, InfoConnettoreUscita infoConnettoreUscita, Map<String, List<String>> trasportoRisposta) throws DumpException {
  257.         
  258.         if(!isActiveDumpDatabaseRisposta()) {
  259.             return;
  260.         }
  261.         
  262.         if(this.dump!=null) {
  263.             //if(content!=null){ // devono essere registrati anche solamente gli header
  264.             this.dump.dumpBinarioRispostaIngresso(this.isDumpBinarioRegistrazioneDatabase(), this.onlyLogFileTraceRispostaIngressoHeaders, this.onlyLogFileTraceRispostaIngressoPayload, 
  265.                     content, messageType, 
  266.                     infoConnettoreUscita, trasportoRisposta);
  267.             //}
  268.         }
  269.     }
  270.     
  271. }
Created with JaCoCo 0.8.8.202204050719