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

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

  31. import org.openspcoop2.core.config.DumpConfigurazione;
  32. import org.openspcoop2.core.config.constants.StatoFunzionalita;
  33. import org.openspcoop2.core.constants.TipoPdD;
  34. import org.openspcoop2.core.id.IDSoggetto;
  35. import org.openspcoop2.message.constants.MessageType;
  36. import org.openspcoop2.pdd.config.OpenSPCoop2Properties;
  37. import org.openspcoop2.pdd.core.PdDContext;
  38. import org.openspcoop2.pdd.logger.Dump;
  39. import org.openspcoop2.pdd.logger.OpenSPCoop2Logger;
  40. import org.openspcoop2.pdd.services.connector.ConnectorException;
  41. import org.openspcoop2.pdd.services.connector.messages.DumpRawConnectorInMessage;
  42. import org.openspcoop2.pdd.services.connector.messages.DumpRawConnectorOutMessage;
  43. import org.openspcoop2.pdd.services.core.AbstractContext;
  44. import org.openspcoop2.protocol.sdk.constants.IDService;
  45. import org.openspcoop2.protocol.sdk.dump.DumpException;
  46. import org.openspcoop2.protocol.sdk.state.URLProtocolContext;
  47. import org.openspcoop2.utils.certificate.CertificateInfo;
  48. import org.openspcoop2.utils.certificate.CertificateUtils;
  49. import org.openspcoop2.utils.date.DateUtils;
  50. import org.openspcoop2.utils.io.DumpByteArrayOutputStream;
  51. import org.openspcoop2.utils.io.notifier.NotifierInputStreamParams;
  52. import org.openspcoop2.utils.transport.Credential;
  53. import org.openspcoop2.utils.transport.TransportUtils;
  54. import org.openspcoop2.utils.transport.http.HttpConstants;
  55. import org.slf4j.Logger;

  57. /**
  58.  * DumpRaw
  59.  * 
  60.  * @author Poli Andrea (apoli@link.it)
  61.  * @author $Author$
  62.  * @version $Rev$, $Date$
  63.  */
  64. public class DumpRaw {

  66.     private StringBuilder bfContext = new StringBuilder();
  67.     private StringBuilder bfRequest = new StringBuilder();
  68.     private StringBuilder bfResponse = new StringBuilder();
  69.     private Logger log;
  70.     private boolean pd;
  71.     private String idTransaction;
  72.     private Logger logDump;
  73.     private Dump dump;
  74.     private boolean dumpBinario;
  75.     private boolean dumpBinario_registrazioneDatabase = false;
  76.     private DumpConfigurazione dumpDatabaseConfigurazione;
  77.     private boolean dumpDatabaseRichiestaIngressoHeaders;
  78.     private boolean dumpDatabaseRichiestaIngressoPayload;
  79.     private boolean dumpDatabaseRispostaUscitaHeaders;
  80.     private boolean dumpDatabaseRispostaUscitaPayload;
  81.     private boolean onlyLogFileTraceRichiestaIngressoHeaders = false;
  82.     private boolean onlyLogFileTraceRichiestaIngressoPayload = false;
  83.     private boolean onlyLogFileTraceRispostaUscitaHeaders = false;
  84.     private boolean onlyLogFileTraceRispostaUscitaPayload = false;
  85.     private URLProtocolContext urlProtocolContext;
  86.     
  87.     private IDSoggetto dominio;
  88.     private String modulo;
  89.     private TipoPdD tipoPdD;
  90.     
  91.     public DumpRaw(Logger log,IDSoggetto dominio,String modulo,TipoPdD tipoPdD, 
  92.             boolean dumpBinario, 
  93.             DumpConfigurazione dumpConfigurazione,
  94.             boolean fileTraceHeaders, boolean fileTraceBody) throws ConnectorException{
  95.         this.log = log;
  96.         
  97.         switch (tipoPdD) {
  98.         case DELEGATA:
  99.             this.pd = true;
  100.             break;
  101.         default:
  102.             this.pd = false;
  103.             break;
  104.         }
  105.         
  106.         this.dumpBinario = dumpBinario;
  107.         if(this.dumpBinario) {
  108.             this.dumpBinario_registrazioneDatabase = OpenSPCoop2Properties.getInstance().isDumpBinarioRegistrazioneDatabase();
  109.         }
  110.         
  111.         if(dumpConfigurazione!=null) {
  112.             if(dumpConfigurazione.getRichiestaIngresso()!=null) {
  113.                 // il parsing deve essere gestito con l'altra modalità, che dovrà gestire anche gli header, senno sul db si troveranno 2 messaggi
  114.                 boolean payloadParsing = StatoFunzionalita.ABILITATO.equals(dumpConfigurazione.getRichiestaIngresso().getPayload()) &&
  115.                         StatoFunzionalita.ABILITATO.equals(dumpConfigurazione.getRichiestaIngresso().getPayloadParsing());
  116.                 if(!payloadParsing) {
  117.                     if(StatoFunzionalita.ABILITATO.equals(dumpConfigurazione.getRichiestaIngresso().getHeaders())){
  118.                         this.dumpDatabaseRichiestaIngressoHeaders = true;
  119.                     }
  120.                     if(StatoFunzionalita.ABILITATO.equals(dumpConfigurazione.getRichiestaIngresso().getPayload())){
  121.                         this.dumpDatabaseRichiestaIngressoPayload = true;
  122.                     }
  123.                 }
  124.             }
  125.             if(dumpConfigurazione.getRispostaUscita()!=null) {
  126.                 // il parsing deve essere gestito con l'altra modalità, che dovrà gestire anche gli header, senno sul db si troveranno 2 messaggi
  127.                 boolean payloadParsing = StatoFunzionalita.ABILITATO.equals(dumpConfigurazione.getRispostaUscita().getPayload()) &&
  128.                         StatoFunzionalita.ABILITATO.equals(dumpConfigurazione.getRispostaUscita().getPayloadParsing());
  129.                 if(!payloadParsing) {
  130.                     if(StatoFunzionalita.ABILITATO.equals(dumpConfigurazione.getRispostaUscita().getHeaders())){
  131.                         this.dumpDatabaseRispostaUscitaHeaders = true;
  132.                     }
  133.                     if(StatoFunzionalita.ABILITATO.equals(dumpConfigurazione.getRispostaUscita().getPayload())){
  134.                         this.dumpDatabaseRispostaUscitaPayload = true;
  135.                     }
  136.                 }
  137.             }
  138.             this.dumpDatabaseConfigurazione = dumpConfigurazione;
  139.         }
  140.         
  141.         if(!this.dumpDatabaseRichiestaIngressoHeaders && (!dumpBinario || !this.dumpBinario_registrazioneDatabase) ) {
  142.             this.onlyLogFileTraceRichiestaIngressoHeaders = fileTraceHeaders;
  143.         }
  144.         if(!this.dumpDatabaseRichiestaIngressoPayload && (!dumpBinario || !this.dumpBinario_registrazioneDatabase) ) {
  145.             this.onlyLogFileTraceRichiestaIngressoPayload = fileTraceBody;
  146.         }
  147.         if(!this.dumpDatabaseRispostaUscitaHeaders && (!dumpBinario || !this.dumpBinario_registrazioneDatabase) ) {
  148.             this.onlyLogFileTraceRispostaUscitaHeaders = fileTraceHeaders;
  149.         }
  150.         if(!this.dumpDatabaseRispostaUscitaPayload && (!dumpBinario || !this.dumpBinario_registrazioneDatabase) ) {
  151.             this.onlyLogFileTraceRispostaUscitaPayload = fileTraceBody;
  152.         }
  153.         
  154.         if(this.dumpBinario) {
  155.             if(this.pd){
  156.                 this.logDump = OpenSPCoop2Logger.getLoggerOpenSPCoopDumpBinarioPD();
  157.             }
  158.             else{
  159.                 this.logDump = OpenSPCoop2Logger.getLoggerOpenSPCoopDumpBinarioPA();
  160.             }
  161.             if(this.logDump==null){
  162.                 throw new ConnectorException("Logger per la registrazione dei dati binari non inizializzato");
  163.             }
  164.         }
  165.         
  166.         this.dominio = dominio;
  167.         this.modulo = modulo;
  168.         this.tipoPdD = tipoPdD;
  169.     }
  170.     
  171.     public boolean isActiveDump() {
  172.         return this.dumpBinario || isRegistrazioneDatabase() || onlyLogFileTrace();
  173.     }
  174.     public boolean isActiveDumpRichiesta() {
  175.         return this.dumpBinario || isRegistrazioneDatabaseRichiesta() || onlyLogFileTraceRichiesta();
  176.     }
  177.     public boolean isActiveDumpRisposta() {
  178.         return this.dumpBinario || isRegistrazioneDatabaseRisposta() || onlyLogFileTraceRisposta();
  179.     }
  180.     
  181.     private boolean isRegistrazioneDatabase() {
  182.         return this.isRegistrazioneDatabaseRichiesta()
  183.                 ||
  184.                this.isRegistrazioneDatabaseRisposta()
  185.                ;
  186.     }
  187.     private boolean isRegistrazioneDatabaseRichiesta() {
  188.         return this.dumpDatabaseRichiestaIngressoHeaders
  189.                 ||
  190.                this.dumpDatabaseRichiestaIngressoPayload
  191.                ;
  192.     }
  193.     private boolean isRegistrazioneDatabaseRisposta() {
  194.         return this.dumpDatabaseRispostaUscitaHeaders
  195.                 ||
  196.                this.dumpDatabaseRispostaUscitaPayload
  197.                ;
  198.     }
  199.     
  200.     private boolean onlyLogFileTrace() {
  201.         return this.onlyLogFileTraceRichiesta()
  202.                 ||
  203.                this.onlyLogFileTraceRisposta()
  204.                ;
  205.     }
  206.     private boolean onlyLogFileTraceRichiesta() {
  207.         return this.onlyLogFileTraceRichiestaIngressoHeaders
  208.                 ||
  209.                this.onlyLogFileTraceRichiestaIngressoPayload
  210.                ;
  211.     }
  212.     private boolean onlyLogFileTraceRisposta() {
  213.         return this.onlyLogFileTraceRispostaUscitaHeaders
  214.                 ||
  215.                this.onlyLogFileTraceRispostaUscitaPayload
  216.                ;
  217.     }
  218.     
  219.     private boolean isDumpBinarioRegistrazioneDatabase() {
  220.         return this.dumpBinario && this.dumpBinario_registrazioneDatabase;
  221.     }
  222.     
  223.     public void setPddContext(String interfaceName, PdDContext pddContext) throws DumpException {
  224.         
  225.         if(!isActiveDump()) {
  226.             return;
  227.         }
  228.         
  229.         if(this.isRegistrazioneDatabase() || this.isDumpBinarioRegistrazioneDatabase() || this.onlyLogFileTrace()) {
  230.             this.dump = new Dump(this.dominio, this.modulo, this.tipoPdD, interfaceName, pddContext, this.dumpDatabaseConfigurazione);
  231.         }   
  232.     }
  233.         
  234.     public void serializeContext(AbstractContext context,String protocol){
  235.         
  236.         if(!isActiveDump()) {
  237.             return;
  238.         }
  239.         
  240.         try{
  241.             Date dataAccettazioneRichiesta = context.getDataAccettazioneRichiesta();
  242.             Date dataIngressoRichiesta = context.getDataIngressoRichiesta();
  243.             String idTransazione = null;
  244.             IDService serviceType = context.getIdModuloAsIDService();
  245.             TipoPdD tipoPdD = context.getTipoPorta();
  246.             if(context.getPddContext()!=null){
  247.                 Object tmp = context.getPddContext().getObject(org.openspcoop2.core.constants.Costanti.ID_TRANSAZIONE);
  248.                 if(tmp!=null){
  249.                     idTransazione = (String) tmp;
  250.                 }
  251.             }
  252.             this.serializeContext(dataAccettazioneRichiesta, dataIngressoRichiesta, idTransazione, serviceType, tipoPdD, protocol);
  253.             
  254.         }catch(Throwable t){
  255.             this.bfContext.append("SerializeContext (AbstractContext) error: "+t.getMessage()+"\n");
  256.             this.log.error("SerializeContext (AbstractContext) error: "+t.getMessage(),t);
  257.         }
  258.     }
  259.     public void serializeContext(Date dataAccettazioneRichiesta,Date dataIngressoRichiesta, String idTransazione, IDService serviceType, TipoPdD tipoPdD,String protocol){
  260.         
  261.         if(!isActiveDump()) {
  262.             return;
  263.         }
  264.         
  265.         if(!this.dumpBinario) {
  266.             return;
  267.         }
  268.         
  269.         this.bfContext.append("------ RequestContext ("+idTransazione+") ------\n");
  270.         this.idTransaction = idTransazione;
  271.         
  272.         try{
  273.             if(dataAccettazioneRichiesta!=null){
  274.                 SimpleDateFormat dateformat = DateUtils.getSimpleDateFormatMs();
  275.                 this.bfContext.append("Date (Accept Request): ");
  276.                 this.bfContext.append(dateformat.format(dataAccettazioneRichiesta));
  277.                 this.bfContext.append("\n");
  278.             }
  279.             if(dataIngressoRichiesta!=null){
  280.                 SimpleDateFormat dateformat = DateUtils.getSimpleDateFormatMs();
  281.                 this.bfContext.append("Date (Received Request): ");
  282.                 this.bfContext.append(dateformat.format(dataIngressoRichiesta));
  283.                 this.bfContext.append("\n");
  284.             }
  285.             if(idTransazione!=null){
  286.                 this.bfContext.append("IdTransaction: ");
  287.                 this.bfContext.append(idTransazione);
  288.                 this.bfContext.append("\n");
  289.             }
  290.             if(protocol!=null){
  291.                 this.bfContext.append("Protocol: ");
  292.                 this.bfContext.append(protocol);
  293.                 this.bfContext.append("\n");
  294.             }
  295.             if(serviceType!=null){
  296.                 this.bfContext.append("Service: ");
  297.                 this.bfContext.append(serviceType.getValue());
  298.                 this.bfContext.append("\n");
  299.             }
  300.             if(tipoPdD!=null){
  301.                 this.bfContext.append("PddType: ");
  302.                 this.bfContext.append(tipoPdD.getTipo());
  303.                 this.bfContext.append("\n");
  304.             }
  305.         }catch(Throwable t){
  306.             this.bfContext.append("SerializeContext error: "+t.getMessage()+"\n");
  307.             this.log.error("SerializeContext error: "+t.getMessage(),t);
  308.         }
  309.         
  310.         this.bfContext.append("------ End-RequestContext ("+this.idTransaction+") ------\n\n");
  311.         
  312.         this.logDump.info(this.bfContext.toString());
  313.         
  314.     }
  315.     
  316.     public void serializeRequest(DumpRawConnectorInMessage req, boolean buildOpenSPCoopMessage, NotifierInputStreamParams notifierInputStreamParams) {
  317.         
  318.         if(!isActiveDumpRichiesta()) {
  319.             return;
  320.         }
  321.         
  322.         String contentType = null;
  323.         try{
  324.             contentType = req.getContentType();
  325.         }catch(Throwable t){
  326.             this.bfRequest.append("Request.getContentType error: "+t.getMessage()+"\n");
  327.             this.log.error("Request.getContentType error: "+t.getMessage(),t);
  328.         }
  329.         
  330.         Integer contentLength =null;
  331.         try{
  332.             contentLength = req.getContentLength();
  333.         }catch(Throwable t){
  334.             this.bfRequest.append("Request.getContentLength error: "+t.getMessage()+"\n");
  335.             this.log.error("Request.getContentLength error: "+t.getMessage(),t);
  336.         }
  337.         
  338.         Credential credential = null;
  339.         try{
  340.             credential = req.getCredential();
  341.         }catch(Throwable t){
  342.             this.bfRequest.append("Request.getIdentity error: "+t.getMessage()+"\n");
  343.             this.log.error("Request.getIdentity error: "+t.getMessage(),t);
  344.         }
  345.         
  346.         this.urlProtocolContext = null;
  347.         try{
  348.             this.urlProtocolContext = req.getURLProtocolContext();
  349.         }catch(Throwable t){
  350.             this.bfRequest.append("Request.getURLProtocolContext error: "+t.getMessage()+"\n");
  351.             this.log.error("Request.getURLProtocolContext error: "+t.getMessage(),t);
  352.         }
  353.         
  354.         if(this.dump!=null && (this.isRegistrazioneDatabaseRichiesta() || this.onlyLogFileTraceRichiesta())) {
  355.             boolean onlyFileTrace = !isRegistrazioneDatabaseRichiesta();
  356.             this.dump.emitDiagnosticStartDumpBinarioRichiestaIngresso(onlyFileTrace);
  357.         }
  358.         
  359.         try{
  360.             // forzo la scrittura nel buffer dell'oggetto DumpRawConnectorInMessage
  361.             if(buildOpenSPCoopMessage){
  362.                 req.getRequest(notifierInputStreamParams);
  363.             }
  364.             else{
  365.                 req.getRequest();
  366.             }
  367.         }catch(Throwable t){
  368.             this.bfRequest.append("Request.getURLProtocolContext error: "+t.getMessage()+"\n");
  369.             this.log.error("Request.getURLProtocolContext error: "+t.getMessage(),t);
  370.         }
  371.         
  372.         DumpByteArrayOutputStream dumpOUT = req.getDumpByteArrayOutputStream();  
  373.         try {
  374.         
  375.             if(this.dumpBinario) {
  376.                 this.serializeRequest(contentType, contentLength, credential, this.urlProtocolContext, 
  377.                         dumpOUT!=null ? dumpOUT.toString() : null,
  378.                         req.getParsingRequestErrorAsString());
  379.             }
  380.             
  381.             if(this.dump!=null && (this.isRegistrazioneDatabaseRichiesta() || this.onlyLogFileTraceRichiesta())) {
  382.                 MessageType messageType = req.getRequestMessageType();
  383.                 //if(rawMessage!=null){ // devono essere registrati anche solamente gli header
  384.                 try {
  385.                     this.dump.dumpBinarioRichiestaIngresso(this.isDumpBinarioRegistrazioneDatabase(), this.onlyLogFileTraceRichiestaIngressoHeaders, this.onlyLogFileTraceRichiestaIngressoPayload, 
  386.                             dumpOUT, messageType,
  387.                             this.urlProtocolContext);
  388.                 }catch(Throwable t){
  389.                     this.log.error("Log DumpBinarioRichiestaIngresso error: "+t.getMessage(),t);
  390.                 }
  391.                 //}
  392.             }
  393.             
  394.         }finally {
  395.             try {
  396.                 if(dumpOUT!=null) {
  397.                     dumpOUT.clearResources();
  398.                 }
  399.             }catch(Throwable t){
  400.                 this.log.error("Log DumpBinarioRichiestaIngresso error (clearResources): "+t.getMessage(),t);
  401.             }
  402.         }

  404.     }
  405.     
  406.     public void serializeRequest(String contentType, Integer contentLength, Credential credential, URLProtocolContext urlProtocolContext, String rawMessage,
  407.             String parsingError) {

  409.         if(!isActiveDumpRichiesta() || !this.dumpBinario) {
  410.             return;
  411.         }

  413.         this.bfRequest.append("------ Request ("+this.idTransaction+") ------\n");
  414.         
  415.         try{
  416.             if(contentType!=null){
  417.                 this.bfRequest.append("ContentType: ");
  418.                 this.bfRequest.append(contentType);
  419.                 this.bfRequest.append("\n");
  420.             }
  421.         }catch(Throwable t){
  422.             this.bfRequest.append("Request.getContentType error: "+t.getMessage());
  423.             this.log.error("Request.getContentType error: "+t.getMessage(),t);
  424.         }
  425.         
  426.         try{
  427.             if(contentLength!=null && contentLength>=0){
  428.                 this.bfRequest.append("ContentLength: ");
  429.                 this.bfRequest.append(contentLength);
  430.                 this.bfRequest.append("\n");
  431.             }
  432.         }catch(Throwable t){
  433.             this.bfRequest.append("Request.getContentLength error: "+t.getMessage()+"\n");
  434.             this.log.error("Request.getContentLength error: "+t.getMessage(),t);
  435.         }
  436.         
  437.         try{
  438.             if(credential!=null){
  439.             
  440.                 String principal = credential.getPrincipal();
  441.                 if(principal!=null){
  442.                     this.bfRequest.append("Principal: ");
  443.                     this.bfRequest.append(principal);
  444.                     this.bfRequest.append("\n");
  445.                 }
  446.                 
  447.                 String username = credential.getUsername();
  448.                 if(username!=null){
  449.                     this.bfRequest.append("Username: ");
  450.                     this.bfRequest.append(username);
  451.                     this.bfRequest.append("\n");
  452.                 }
  453.                 
  454.                 String password = credential.getPassword();
  455.                 if(password!=null){
  456.                     this.bfRequest.append("Password: ");
  457.                     this.bfRequest.append(password);
  458.                     this.bfRequest.append("\n");
  459.                 }
  460.                 
  461.                 String subjectX509 = credential.getSubject();
  462.                 if(subjectX509!=null){
  463.                     this.bfRequest.append("X509.Subject: ");
  464.                     this.bfRequest.append(subjectX509);
  465.                     this.bfRequest.append("\n");
  466.                 }
  467.                 
  468.                 if(credential.getCertificate()!=null){
  469.                     List<X509Certificate> certificates = new ArrayList<>();
  470.                     if(credential.getCertificate().getCertificate()!=null && credential.getCertificate().getCertificate().getCertificate()!=null) {
  471.                         certificates.add(credential.getCertificate().getCertificate().getCertificate());
  472.                     }
  473.                     if(credential.getCertificate().getCertificateChain()!=null && credential.getCertificate().getCertificateChain().size()>0) {
  474.                         for (CertificateInfo cInfo : credential.getCertificate().getCertificateChain()) {
  475.                             if(cInfo.getCertificate()!=null) {
  476.                                 certificates.add(cInfo.getCertificate());
  477.                             }
  478.                         }
  479.                     }
  480.                     if(!certificates.isEmpty()) {
  481.                         CertificateUtils.printCertificate(this.bfRequest, certificates);
  482.                     }
  483.                 }
  484.             }
  485.             
  486.         }catch(Throwable t){
  487.             this.bfRequest.append("Request.getIdentity error: "+t.getMessage()+"\n");
  488.             this.log.error("Request.getIdentity error: "+t.getMessage(),t);
  489.         }
  490.         
  491.         try{
  492.             if(urlProtocolContext!=null){
  493.             
  494.                 String urlInvocazione = urlProtocolContext.getUrlInvocazione_formBased();
  495.                 if(urlInvocazione!=null){
  496.                     this.bfRequest.append("URLInvocazione: ");
  497.                     this.bfRequest.append(urlInvocazione);
  498.                     this.bfRequest.append("\n");
  499.                 }
  500.                 
  501.                 String function = urlProtocolContext.getFunction();
  502.                 if(function!=null){
  503.                     this.bfRequest.append("Function: ");
  504.                     this.bfRequest.append(function);
  505.                     this.bfRequest.append("\n");
  506.                 }
  507.                 
  508. //              String webContext = urlProtocolContext.getWebContext();
  509. //              if(webContext!=null){
  510. //                  this.bfRequest.append("WEBContext: ");
  511. //                  this.bfRequest.append(function);
  512. //                  this.bfRequest.append("\n");
  513. //              }
  514.                 
  515.                 Map<String, List<String>> transportHeader = urlProtocolContext.getHeaders();
  516.                 if(transportHeader!=null && transportHeader.size()>0){
  517.                     this.bfRequest.append("TransportHeaders: "+transportHeader.size()+"\n");
  518.                     Iterator<String> keys = transportHeader.keySet().iterator();
  519.                     while (keys.hasNext()) {
  520.                         String key = (String) keys.next();
  521.                         List<String> values = transportHeader.get(key);
  522.                         if(values!=null && !values.isEmpty()) {
  523.                             for (String value : values) {
  524.                                 this.bfRequest.append("\t"+key+"="+value+"\n");
  525.                             }
  526.                         }
  527.                     }
  528.                 }
  529.                 else{
  530.                     this.bfRequest.append("TransportHeaders: "+0+"\n");
  531.                 }
  532.                 
  533.                 Map<String, List<String>> parameterUrl = urlProtocolContext.getParameters();
  534.                 if(parameterUrl!=null && parameterUrl.size()>0){
  535.                     this.bfRequest.append("URLParameters: "+parameterUrl.size()+"\n");
  536.                     Iterator<String> keys = parameterUrl.keySet().iterator();
  537.                     while (keys.hasNext()) {
  538.                         String key = (String) keys.next();
  539.                         List<String> values = parameterUrl.get(key);
  540.                         if(values!=null && !values.isEmpty()) {
  541.                             for (String value : values) {
  542.                                 this.bfRequest.append("\t"+key+"="+value+"\n");
  543.                             }
  544.                         }
  545.                     }
  546.                 }
  547.                 else{
  548.                     this.bfRequest.append("URLParameters: "+0+"\n");
  549.                 }
  550.                 
  551.             }
  552.             
  553.         }catch(Throwable t){
  554.             this.bfRequest.append("Request.getURLProtocolContext error: "+t.getMessage()+"\n");
  555.             this.log.error("Request.getURLProtocolContext error: "+t.getMessage(),t);
  556.         }
  557.                 
  558.         if(rawMessage!=null){
  559.             this.bfRequest.append("Binary Request Length: ");
  560.             this.bfRequest.append(rawMessage.length());
  561.             this.bfRequest.append("\n");
  562.             
  563.             this.bfRequest.append("Binary Request: \n");
  564.             this.bfRequest.append(rawMessage);
  565.             this.bfRequest.append("\n");
  566.             
  567.         }
  568.         else if(parsingError!=null){
  569.             this.bfRequest.append("Parsing Request Exception: \n");
  570.             this.bfRequest.append(parsingError);
  571.             this.bfRequest.append("\n");
  572.         }
  573.         else{
  574.             this.bfRequest.append("Binary Request Length: ");
  575.             this.bfRequest.append(0);
  576.             this.bfRequest.append("\n");
  577.             
  578.             this.bfRequest.append("Binary Request: \n");
  579.             this.bfRequest.append("Nessuna contenuto presente nel payload");
  580.             this.bfRequest.append("\n");
  581.         }
  582.         
  583.         this.bfRequest.append("------ End-Request ("+this.idTransaction+") ------\n\n");
  584.         
  585.         this.logDump.info(this.bfRequest.toString());
  586.                 
  587.     }
  588.     
  589.     public void emitDiagnosticStartDumpBinarioRispostaUscita() {
  590.         if(this.dump!=null && (this.isRegistrazioneDatabaseRisposta() || this.onlyLogFileTraceRisposta())) {
  591.             boolean onlyFileTrace = !isRegistrazioneDatabaseRisposta();
  592.             this.dump.emitDiagnosticStartDumpBinarioRispostaUscita(onlyFileTrace);
  593.         }
  594.     } 
  595.     
  596.     public void serializeResponse(DumpRawConnectorOutMessage res) {
  597.         
  598.         if(!isActiveDumpRisposta()) {
  599.             return;
  600.         }
  601.         
  602.         DumpByteArrayOutputStream dumpOUT = res.getDumpByteArrayOutputStream();  
  603.         try {
  604.         
  605.             if(this.dumpBinario) {
  606.                 this.serializeResponse(dumpOUT!=null ? dumpOUT.toString() : null,
  607.                         res.getParsingResponseErrorAsString(),
  608.                         res.getTrasporto(),res.getContentLenght(),res.getContentType(),res.getStatus());
  609.             }
  610.             
  611.             if(this.dump!=null && (this.isRegistrazioneDatabaseRisposta() || this.onlyLogFileTraceRisposta())) {
  612.                 MessageType messageType = res.getMessageType();
  613.                 //if(rawMessage!=null){ // devono essere registrati anche solamente gli header
  614.                 try {
  615.                     if(res.getContentType()!=null) {
  616.                         TransportUtils.setHeader(res.getTrasporto(),HttpConstants.CONTENT_TYPE,res.getContentType());
  617.                     }
  618.                     this.dump.dumpBinarioRispostaUscita(this.isDumpBinarioRegistrazioneDatabase(), this.onlyLogFileTraceRispostaUscitaHeaders, this.onlyLogFileTraceRispostaUscitaPayload,
  619.                             dumpOUT, messageType, 
  620.                             this.urlProtocolContext, res.getTrasporto());
  621.                 }catch(Throwable t){
  622.                     this.log.error("Log DumpBinarioRispostaUscita error: "+t.getMessage(),t);
  623.                 }
  624.                 //}
  625.             }
  626.         }finally {
  627.             try {
  628.                 if(dumpOUT!=null) {
  629.                     dumpOUT.clearResources();
  630.                 }
  631.             }catch(Throwable t){
  632.                 this.log.error("Log DumpBinarioRispostaUscita error (clearResources): "+t.getMessage(),t);
  633.             }
  634.         }
  635.     }
  636.     
  637.     public void serializeResponse(String rawMessage,String parsingError,Map<String, List<String>> transportHeader,Integer contentLength, String contentType, Integer status) {
  638.         
  639.         if(!isActiveDumpRisposta() || !this.dumpBinario) {
  640.             return;
  641.         }
  642.         
  643.         this.bfResponse.append("------ Response ("+this.idTransaction+") ------\n");
  644.         
  645.         try{
  646.             if(contentType!=null){
  647.                 this.bfResponse.append("ContentType: ");
  648.                 this.bfResponse.append(contentType);
  649.                 this.bfResponse.append("\n");
  650.             }
  651.         }catch(Throwable t){
  652.             this.bfResponse.append("Response.contentType error: "+t.getMessage());
  653.             this.log.error("Response.contentType error: "+t.getMessage(),t);
  654.         }
  655.         
  656.         try{
  657.             if(contentLength!=null && contentLength>=0){
  658.                 this.bfResponse.append("ContentLength: ");
  659.                 this.bfResponse.append(contentLength);
  660.                 this.bfResponse.append("\n");
  661.             }
  662.         }catch(Throwable t){
  663.             this.bfResponse.append("Response.contentLength error: "+t.getMessage()+"\n");
  664.             this.log.error("Response.contentLength error: "+t.getMessage(),t);
  665.         }
  666.         
  667.         try{
  668.             if(status!=null){
  669.                 this.bfResponse.append("Status: ");
  670.                 this.bfResponse.append(status);
  671.                 this.bfResponse.append("\n");
  672.             }
  673.         }catch(Throwable t){
  674.             this.bfResponse.append("Response.status error: "+t.getMessage()+"\n");
  675.             this.log.error("Response.status error: "+t.getMessage(),t);
  676.         }
  677.         
  678.         if(transportHeader!=null && transportHeader.size()>0){
  679.             this.bfResponse.append("TransportHeaders: "+transportHeader.size()+"\n");
  680.             Iterator<String> keys = transportHeader.keySet().iterator();
  681.             while (keys.hasNext()) {
  682.                 String key = (String) keys.next();
  683.                 List<String> values = transportHeader.get(key);
  684.                 if(values!=null && !values.isEmpty()) {
  685.                     for (String value : values) {
  686.                         this.bfResponse.append("\t"+key+"="+value+"\n");
  687.                     }
  688.                 }
  689.             }
  690.         }
  691.         else{
  692.             this.bfResponse.append("TransportHeaders: "+0+"\n");
  693.         }
  694.         
  695.         if(rawMessage!=null){
  696.             this.bfResponse.append("Binary Response Length: ");
  697.             this.bfResponse.append(rawMessage.length());
  698.             this.bfResponse.append("\n");
  699.             
  700.             this.bfResponse.append("Binary Response: \n");
  701.             this.bfResponse.append(rawMessage);
  702.             this.bfResponse.append("\n");
  703.             
  704.         }
  705.         else if(parsingError!=null){
  706.             this.bfRequest.append("Parsing Response Exception: \n");
  707.             this.bfRequest.append(parsingError);
  708.             this.bfRequest.append("\n");
  709.         }
  710.         else{
  711.             this.bfResponse.append("Binary Response Length: ");
  712.             this.bfResponse.append(0);
  713.             this.bfResponse.append("\n");
  714.             
  715.             this.bfResponse.append("Binary Response: \n");
  716.             this.bfResponse.append("Nessuna contenuto presente nel payload");
  717.             this.bfResponse.append("\n");
  718.         }
  719.         
  720.         this.bfResponse.append("------ End-Response ("+this.idTransaction+") ------\n\n");
  721.         
  722.         this.logDump.info(this.bfResponse.toString());
  723.     }
  724.     
  725. }
Created with JaCoCo 0.8.8.202204050719