DaoBuilder.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.protocol.engine.builder;

  23. import java.io.ByteArrayOutputStream;
  24. import java.io.PrintWriter;
  25. import java.util.Date;

  27. import org.openspcoop2.core.constants.TipoPdD;
  28. import org.openspcoop2.core.eccezione.details.Dettagli;
  29. import org.openspcoop2.core.eccezione.details.Dettaglio;
  30. import org.openspcoop2.core.eccezione.details.DettaglioEccezione;
  31. import org.openspcoop2.core.eccezione.details.Dominio;
  32. import org.openspcoop2.core.eccezione.details.DominioSoggetto;
  33. import org.openspcoop2.core.eccezione.details.Eccezione;
  34. import org.openspcoop2.core.eccezione.details.Eccezioni;
  35. import org.openspcoop2.core.eccezione.details.constants.TipoEccezione;
  36. import org.openspcoop2.core.id.IDSoggetto;
  37. import org.openspcoop2.message.config.IntegrationErrorReturnConfiguration;
  38. import org.openspcoop2.protocol.basic.Costanti;
  39. import org.openspcoop2.protocol.sdk.IProtocolFactory;
  40. import org.openspcoop2.protocol.sdk.ProtocolException;
  41. import org.openspcoop2.protocol.sdk.config.IProtocolManager;
  42. import org.openspcoop2.protocol.sdk.constants.IntegrationFunctionError;
  43. import org.openspcoop2.protocol.utils.ErroriProperties;
  44. import org.openspcoop2.utils.date.DateManager;

  46. /**
  47.  * DAOBuilder
  48.  *
  49.  * @author Poli Andrea (apoli@link.it)
  50.  * @author $Author$
  51.  * @version $Rev$, $Date$
  52.  */


  55. public class DaoBuilder {
  56.     /** ------------------- Metodi che generano un DettaglioEccezione ---------------- */

  58.     public static Dominio buildDominio(IDSoggetto identitaPdD,TipoPdD tipoPdD,String modulo){
  59.         org.openspcoop2.core.eccezione.details.constants.TipoPdD idFunzione = null;
  60.         if(TipoPdD.DELEGATA.equals(tipoPdD)){
  61.             idFunzione = org.openspcoop2.core.eccezione.details.constants.TipoPdD.OUTBOUND_PROXY;
  62.         }
  63.         else if(TipoPdD.APPLICATIVA.equals(tipoPdD)){
  64.             idFunzione = org.openspcoop2.core.eccezione.details.constants.TipoPdD.INBOUND_PROXY;
  65.         }
  66.         else if(TipoPdD.INTEGRATION_MANAGER.equals(tipoPdD)){
  67.             idFunzione = org.openspcoop2.core.eccezione.details.constants.TipoPdD.INTEGRATION_MANAGER;
  68.         }
  69.         else if(TipoPdD.ROUTER.equals(tipoPdD)){
  70.             idFunzione = org.openspcoop2.core.eccezione.details.constants.TipoPdD.ROUTER;
  71.         }
  72.         
  73.         Dominio dominio = new Dominio();
  74.         DominioSoggetto dominioSoggetto = new DominioSoggetto();
  75.         dominioSoggetto.setBase(identitaPdD.getNome());
  76.         dominioSoggetto.setType(identitaPdD.getTipo());
  77.         dominio.setOrganization(dominioSoggetto);
  78.         dominio.setId(identitaPdD.getCodicePorta());
  79.         dominio.setRole(idFunzione);
  80.         dominio.setModule(modulo);
  81.         return dominio;
  82.     }
  83.     
  84.     private static void setCodeInEccezione(String codErrore,  org.openspcoop2.core.eccezione.details.Eccezione eccezione,
  85.             IntegrationErrorReturnConfiguration returnConfig, IntegrationFunctionError functionError, ErroriProperties erroriProperties) throws ProtocolException {
  86.         if(Costanti.isTRANSACTION_ERROR_STATUS_ABILITATO()){
  87.             eccezione.setCode(codErrore);
  88.         }
  89.         else {
  90.             String govwayType = erroriProperties.getErrorType(functionError);
  91.             eccezione.setCode(govwayType);
  92.         }
  93.     }
  94.     private static void setDescriptionInEccezione(String descrErrore,  org.openspcoop2.core.eccezione.details.Eccezione eccezione,
  95.             IntegrationErrorReturnConfiguration returnConfig, IntegrationFunctionError functionError, ErroriProperties erroriProperties) throws ProtocolException {
  96.         
  97.         boolean genericDetails = returnConfig.isGenericDetails();
  98.         if(!genericDetails && erroriProperties.isForceGenericDetails(functionError)) {
  99.             genericDetails = true;
  100.         }
  101.         if (Costanti.isTRANSACTION_FORCE_SPECIFIC_ERROR_DETAILS()) {
  102.             genericDetails = false;
  103.         }
  104.         
  105.         if(genericDetails){
  106.             String govwayDetails = erroriProperties.getGenericDetails(functionError);
  107.             eccezione.setDescription(govwayDetails);
  108.         }
  109.         else {
  110.             eccezione.setDescription(descrErrore);
  111.         }
  112.     }
  113.     private static void addDettaglio(Dettaglio dettaglio, DettaglioEccezione dettaglioEccezione,
  114.             IntegrationErrorReturnConfiguration returnConfig, IntegrationFunctionError functionError, ErroriProperties erroriProperties) throws ProtocolException {
  115.         if(dettaglio != null){
  116.             
  117.             boolean genericDetails = returnConfig.isGenericDetails();
  118.             if(!genericDetails && erroriProperties.isForceGenericDetails(functionError)) {
  119.                 genericDetails = true;
  120.             }
  121.             if (Costanti.isTRANSACTION_FORCE_SPECIFIC_ERROR_DETAILS()) {
  122.                 genericDetails = false;
  123.             }
  124.             
  125.             if(!genericDetails) {
  126.                 if(dettaglioEccezione.getDetails()==null){
  127.                     dettaglioEccezione.setDetails(new Dettagli());
  128.                 }
  129.                 dettaglioEccezione.getDetails().addDetail(dettaglio);
  130.             }
  131.         }
  132.     }
  133.     
  134.     public static DettaglioEccezione buildDettaglioEccezione(IDSoggetto identitaPdD,TipoPdD tipoPdD,String modulo, String codErrore,String msgErrore,boolean isErroreProtocollo,
  135.             IntegrationErrorReturnConfiguration returnConfig, IntegrationFunctionError functionError, ErroriProperties erroriProperties) throws ProtocolException{
  136.         DettaglioEccezione dettaglioEccezione = new DettaglioEccezione();
  137.             
  138.         dettaglioEccezione.setTimestamp(DateManager.getDate());
  139.         
  140.         dettaglioEccezione.setDomain(buildDominio(identitaPdD, tipoPdD, modulo));
  141.         
  142.         org.openspcoop2.core.eccezione.details.Eccezione eccezione = new org.openspcoop2.core.eccezione.details.Eccezione();
  143.         setCodeInEccezione(codErrore, eccezione, returnConfig, functionError, erroriProperties);
  144.         setDescriptionInEccezione(msgErrore, eccezione, returnConfig, functionError, erroriProperties);
  145.         if(isErroreProtocollo){
  146.             eccezione.setType(TipoEccezione.PROTOCOL);
  147.         }else{
  148.             eccezione.setType(TipoEccezione.INTEGRATION);
  149.         }
  150.         if(dettaglioEccezione.getExceptions()==null){
  151.             dettaglioEccezione.setExceptions(new Eccezioni());
  152.         }
  153.         dettaglioEccezione.getExceptions().addException(eccezione);
  154.         return dettaglioEccezione;
  155.     }
  156.     
  157.     public static DettaglioEccezione buildDettaglioEccezione(Date oraRegistrazione, IDSoggetto identitaPdD,TipoPdD tipoPdD, String modulo, Eccezione eccezione, Dettaglio dettaglio,
  158.             IntegrationErrorReturnConfiguration returnConfig, IntegrationFunctionError functionError, ErroriProperties erroriProperties) throws ProtocolException{
  159.         DettaglioEccezione dettaglioEccezione = new DettaglioEccezione();

  161.         // info generali
  162.         dettaglioEccezione.setTimestamp(oraRegistrazione);
  163.         
  164.         dettaglioEccezione.setDomain(buildDominio(identitaPdD, tipoPdD, modulo));
  165.         
  166.         if(eccezione != null){
  167.             if(dettaglioEccezione.getExceptions()==null){
  168.                 dettaglioEccezione.setExceptions(new Eccezioni());
  169.             }
  170.             
  171.             setCodeInEccezione(eccezione.getCode(), eccezione, returnConfig, functionError, erroriProperties);
  172.             setDescriptionInEccezione(eccezione.getDescription(), eccezione, returnConfig, functionError, erroriProperties);
  173.             
  174.             dettaglioEccezione.getExceptions().addException(eccezione);
  175.         }
  176.         
  177.         if(dettaglio != null){
  178.             addDettaglio(dettaglio, dettaglioEccezione, returnConfig, functionError, erroriProperties);
  179.         }
  180.         return dettaglioEccezione;
  181.     }
  182.     
  183.     public static Eccezione buildEccezione(String codice, String descrizione, String rilevanza, String contesto, boolean isErroreProtocollo){
  184.         Eccezione eccezione = new Eccezione();
  185.         eccezione.setCode(codice);
  186.         eccezione.setDescription(descrizione);
  187.         eccezione.setSeverity(rilevanza);
  188.         eccezione.setContext(contesto);
  189.         if(isErroreProtocollo){
  190.             eccezione.setType(TipoEccezione.PROTOCOL);
  191.         }else{
  192.             eccezione.setType(TipoEccezione.INTEGRATION);
  193.         }
  194.         return eccezione;
  195.     }
  196.     
  197.     public static Dettaglio buildDettagio(String tipo, String base){
  198.         Dettaglio dettaglio = new Dettaglio();
  199.         dettaglio.setType(tipo);
  200.         dettaglio.setBase(base);
  201.         return dettaglio;
  202.     }
  203.     
  204.     
  205.     
  206.     
  207.     
  208.     
  209.     
  210.     
  211.     
  212.     public static void gestioneDettaglioEccezioneIntegrazione(IProtocolFactory<?> protocolFactory,Exception eProcessamento,DettaglioEccezione dettaglioEccezione,boolean generaInformazioniGeneriche) throws ProtocolException{
  213.         IProtocolManager protocolManager = protocolFactory.createProtocolManager();
  214.         DaoBuilder.gestioneDettaglioEccezioneProcessamento_engine(eProcessamento, dettaglioEccezione, 
  215.                 protocolManager.isGenerazioneDetailsFaultIntegrationeConStackTrace(),
  216.                 generaInformazioniGeneriche);
  217.     }
  218.     public static void gestioneDettaglioEccezioneProcessamento(IProtocolFactory<?> protocolFactory,Exception eProcessamento,DettaglioEccezione dettaglioEccezione) throws ProtocolException{
  219.         IProtocolManager protocolManager = protocolFactory.createProtocolManager();
  220.         DaoBuilder.gestioneDettaglioEccezioneProcessamento_engine(eProcessamento, dettaglioEccezione, 
  221.                 protocolManager.isGenerazioneDetailsFaultProtocolloConStackTrace(),
  222.                 protocolManager.isGenerazioneDetailsFaultProtocolloConInformazioniGeneriche());
  223.     }
  224.     
  225.     private static void gestioneDettaglioEccezioneProcessamento_engine(Exception eProcessamento,DettaglioEccezione dettaglioEccezione,
  226.             boolean generaStackTrace,boolean generaInformazioniGeneriche){
  227.         if(eProcessamento!=null){

  229.             if(generaInformazioniGeneriche){

  231.                 Dettaglio detail = new Dettaglio();
  232.                 detail.setType("causa");

  234.                 String msg = null;
  235.                 if(eProcessamento.getMessage()!=null){
  236.                     msg = eProcessamento.getMessage();
  237.                 }else{
  238.                     msg = eProcessamento.toString();
  239.                 }
  240.                 //System.out.println("MESSAGE ["+msg+"]");
  241.                 // faccio viaggiare solo le informazioni che ritengo pubbliche
  242.                 if("Connection refused".equals(msg)){
  243.                     msg = "Connection refused";
  244.                     detail.setBase(msg);
  245.                     if(dettaglioEccezione.getDetails()==null){
  246.                         dettaglioEccezione.setDetails(new Dettagli());
  247.                     }
  248.                     dettaglioEccezione.getDetails().addDetail(detail);          
  249.                 }else if("Read timed out".equals(msg)){
  250.                     msg = "Read timed out";
  251.                     detail.setBase(msg);
  252.                     if(dettaglioEccezione.getDetails()==null){
  253.                         dettaglioEccezione.setDetails(new Dettagli());
  254.                     }
  255.                     dettaglioEccezione.getDetails().addDetail(detail);  
  256.                 }else if("connect timed out".equals(msg)){
  257.                     msg = "Connect timed out";
  258.                     detail.setBase(msg);
  259.                     if(dettaglioEccezione.getDetails()==null){
  260.                         dettaglioEccezione.setDetails(new Dettagli());
  261.                     }
  262.                     dettaglioEccezione.getDetails().addDetail(detail);  
  263.                 }

  265.             }else{
  266.                 String base;
  267.                 if(eProcessamento.getMessage()!=null)
  268.                     base = eProcessamento.getMessage();
  269.                 else
  270.                     base = eProcessamento.toString();
  271.                 
  272.                 Dettaglio detail = DaoBuilder.buildDettagio("causa",base);
  273.                 
  274.                 if(dettaglioEccezione.getDetails()==null){
  275.                     dettaglioEccezione.setDetails(new Dettagli());
  276.                 }
  277.                 dettaglioEccezione.getDetails().addDetail(detail);

  279.                 if(eProcessamento.getCause()!=null){
  280.                     DaoBuilder.gestioneDettaglioEccezioneProcessamento_engine_InnerException(eProcessamento.getCause(), dettaglioEccezione);
  281.                 }

  283.                 if(generaStackTrace){
  284.                     Dettaglio detailStackTrace = new Dettaglio();
  285.                     detailStackTrace.setType("stackTrace");
  286.                     ByteArrayOutputStream bout = new ByteArrayOutputStream();
  287.                     PrintWriter pWriter = new PrintWriter(bout);
  288.                     eProcessamento.printStackTrace(pWriter);
  289.                     try{
  290.                         bout.flush();
  291.                         pWriter.flush();
  292.                         pWriter.close();
  293.                         bout.close();
  294.                     }catch(Exception eClose){
  295.                         System.err.println("ERRORE buildEccezioneProcessamentoFromBusta: "+eClose.getMessage());
  296.                     }
  297.                     detailStackTrace.setBase(bout.toString());
  298.                     if(dettaglioEccezione.getDetails()==null){
  299.                         dettaglioEccezione.setDetails(new Dettagli());
  300.                     }
  301.                     dettaglioEccezione.getDetails().addDetail(detailStackTrace);
  302.                 }
  303.             }
  304.         }
  305.     }
  306.     
  307.     private static void gestioneDettaglioEccezioneProcessamento_engine_InnerException(Throwable e,DettaglioEccezione dettaglioEccezione){
  308.         if(e!=null){
  309.             String base;
  310.             if(e.getMessage()!=null)
  311.                 base = e.getMessage();
  312.             else
  313.                 base = e.toString();
  314.             
  315.             Dettaglio detail = DaoBuilder.buildDettagio("causato da", base);
  316.             
  317.             
  318.             if(dettaglioEccezione.getDetails()==null){
  319.                 dettaglioEccezione.setDetails(new Dettagli());
  320.             }
  321.             dettaglioEccezione.getDetails().addDetail(detail);

  323.             if(e.getCause()!=null){
  324.                 DaoBuilder.gestioneDettaglioEccezioneProcessamento_engine_InnerException(e.getCause(), dettaglioEccezione);
  325.             }
  326.         }
  327.     }
  328. }
Created with JaCoCo 0.8.8.202204050719