GeneratoreMessaggiErrore.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.controllo_traffico;

  23. import java.util.List;

  25. import org.openspcoop2.core.controllo_traffico.constants.TipoErrore;
  26. import org.openspcoop2.message.constants.ServiceBinding;
  27. import org.openspcoop2.pdd.core.PdDContext;
  28. import org.openspcoop2.pdd.core.handlers.HandlerException;
  29. import org.openspcoop2.protocol.basic.Costanti;
  30. import org.openspcoop2.protocol.sdk.Context;
  31. import org.openspcoop2.protocol.sdk.ProtocolException;
  32. import org.openspcoop2.protocol.sdk.constants.EsitoTransazioneName;
  33. import org.openspcoop2.protocol.sdk.constants.IntegrationFunctionError;
  34. import org.openspcoop2.protocol.utils.ErroriProperties;
  35. import org.openspcoop2.utils.Map;
  36. import org.openspcoop2.utils.MapKey;
  37. import org.openspcoop2.utils.transport.http.HttpConstants;
  38. import org.slf4j.Logger;

  40. /**     
  41.  * GeneratoreMessaggiErrore
  42.  *
  43.  * @author Poli Andrea (poli@link.it)
  44.  * @author $Author$
  45.  * @version $Rev$, $Date$
  46.  */
  47. public class GeneratoreMessaggiErrore {
  48.     
  49.     private GeneratoreMessaggiErrore() {}

  51.     
  52.     // identificativi diagnostici parziali per policy violate
  53.     public static final String MSG_DIAGNOSTICO_INTERCEPTOR_POLICY_VIOLATA_NUMERO_RICHIESTE_SIMULTANEE = "controlloTraffico.policy.violata.risorsaNumeroRichieste.simultaneo";
  54.     public static final String MSG_DIAGNOSTICO_INTERCEPTOR_POLICY_VIOLATA_NUMERO_RICHIESTE = "controlloTraffico.policy.violata.risorsaNumeroRichieste";
  55.     public static final String MSG_DIAGNOSTICO_INTERCEPTOR_POLICY_VIOLATA_OCCUPAZIONE_BANDA = "controlloTraffico.policy.violata.risorsaOccupazioneBanda";
  56.     public static final String MSG_DIAGNOSTICO_INTERCEPTOR_POLICY_VIOLATA_TEMPO_COMPLESSIVO = "controlloTraffico.policy.violata.risorsaTempoComplessivo";
  57.     public static final String MSG_DIAGNOSTICO_INTERCEPTOR_POLICY_VIOLATA_TEMPO_MEDIO = "controlloTraffico.policy.violata.risorsaTempoMedio";
  58.     public static final String MSG_DIAGNOSTICO_INTERCEPTOR_POLICY_VIOLATA_NUMERO_RICHIESTE_COMPLETATE_CON_SUCCESSO = "controlloTraffico.policy.violata.risorsaNumeroRichiesteCompletateConSuccesso";
  59.     public static final String MSG_DIAGNOSTICO_INTERCEPTOR_POLICY_VIOLATA_NUMERO_RICHIESTE_FALLITE = "controlloTraffico.policy.violata.risorsaNumeroRichiesteFallite";
  60.     public static final String MSG_DIAGNOSTICO_INTERCEPTOR_POLICY_VIOLATA_NUMERO_FAULT_APPLICATIVI = "controlloTraffico.policy.violata.risorsaNumeroFaultApplicativi";
  61.     public static final String MSG_DIAGNOSTICO_INTERCEPTOR_POLICY_VIOLATA_NUMERO_RICHIESTE_FALLITE_O_FAULT_APPLICATIVI= "controlloTraffico.policy.violata.risorsaNumeroRichiesteFalliteOFaultApplicativi";
  62.     public static final String MSG_DIAGNOSTICO_INTERCEPTOR_POLICY_VIOLATA_NUMERO_RICHIESTE_COMPLETATE_CON_SUCCESSO_O_FAULT_APPLICATIVI = "controlloTraffico.policy.violata.risorsaNumeroRichiesteCompletateConSuccessoOFaultApplicativi";
  63.     
  64.     // identificativi diagnostici parziali per applicabilità policy
  65.     public static final String MSG_DIAGNOSTICO_INTERCEPTOR_POLICY_APPLICABILITA_PDD_NON_CONGESTIONATA = "controlloTraffico.policy.applicabilita.nonCongestionato";
  66.     public static final String MSG_DIAGNOSTICO_INTERCEPTOR_POLICY_APPLICABILITA_PDD_NON_CONGESTIONATA_CONTROLLO_DISABILITATO = "controlloTraffico.policy.applicabilita.controlloCongestioneDisabilitato";
  67.     public static final String MSG_DIAGNOSTICO_INTERCEPTOR_POLICY_APPLICABILITA_DEGRADO_PRESTAZIONALE_RILEVATO = "controlloTraffico.policy.applicabilita.degradoPrestazionale.rilevato";
  68.     public static final String MSG_DIAGNOSTICO_INTERCEPTOR_POLICY_APPLICABILITA_DEGRADO_PRESTAZIONALE_NON_RILEVATO = "controlloTraffico.policy.applicabilita.degradoPrestazionale.nonRilevato";
  69.     public static final String MSG_DIAGNOSTICO_INTERCEPTOR_POLICY_APPLICABILITA_STATO_ALLARME_RILEVATO = "controlloTraffico.policy.applicabilita.statoAllarme.rilevato";
  70.     public static final String MSG_DIAGNOSTICO_INTERCEPTOR_POLICY_APPLICABILITA_STATO_ALLARME_NON_RILEVATO = "controlloTraffico.policy.applicabilita.statoAllarme.nonRilevato";
  71.     
  72.     // identificativi diagnostici
  73.     public static final String MSG_DIAGNOSTICO_INTERCEPTOR_CONTROLLO_TRAFFICO_MAXREQUESTS_VIOLATED = "controlloTraffico.maxRequestsViolated";
  74.     public static final String MSG_DIAGNOSTICO_INTERCEPTOR_CONTROLLO_TRAFFICO_MAXREQUESTS_VIOLATED_WARNING_ONLY = "controlloTraffico.maxRequestsViolatedWarningOnly";
  75.     public static final String MSG_DIAGNOSTICO_INTERCEPTOR_CONTROLLO_TRAFFICO_PDD_CONGESTIONATA = "controlloTraffico.pddCongestionata";
  76.     public static final String MSG_DIAGNOSTICO_INTERCEPTOR_CONTROLLO_TRAFFICO_POLICY_CONTROLLO_IN_CORSO = "controlloTraffico.policy.controlloInCorso";
  77.     public static final String MSG_DIAGNOSTICO_INTERCEPTOR_CONTROLLO_TRAFFICO_POLICY_CONTROLLO_TERMINATO_CON_SUCCESSO = "controlloTraffico.policy.controlloTerminato.richiestaNonBloccata";
  78.     public static final String MSG_DIAGNOSTICO_INTERCEPTOR_CONTROLLO_TRAFFICO_POLICY_CONTROLLO_TERMINATO_CON_ERRORE = "controlloTraffico.policy.controlloTerminato.richiestaBloccata";
  79.     public static final String MSG_DIAGNOSTICO_INTERCEPTOR_CONTROLLO_TRAFFICO_POLICY_DISABILITATA = "controlloTraffico.policy.disabilitata";
  80.     public static final String MSG_DIAGNOSTICO_INTERCEPTOR_CONTROLLO_TRAFFICO_POLICY_FILTRATA = "controlloTraffico.policy.filtrata";
  81.     public static final String MSG_DIAGNOSTICO_INTERCEPTOR_CONTROLLO_TRAFFICO_POLICY_NON_APPLICABILE = "controlloTraffico.policy.nonApplicabile";
  82.     public static final String MSG_DIAGNOSTICO_INTERCEPTOR_CONTROLLO_TRAFFICO_POLICY_VIOLATA = "controlloTraffico.policy.violata";
  83.     public static final String MSG_DIAGNOSTICO_INTERCEPTOR_CONTROLLO_TRAFFICO_POLICY_VIOLATA_WARNING_ONLY = "controlloTraffico.policy.violataWarningOnly";
  84.     public static final String MSG_DIAGNOSTICO_INTERCEPTOR_CONTROLLO_TRAFFICO_POLICY_RISPETTATA = "controlloTraffico.policy.rispettata";
  85.     public static final String MSG_DIAGNOSTICO_INTERCEPTOR_CONTROLLO_TRAFFICO_POLICY_IN_ERRORE = "controlloTraffico.policy.inErrore";
  86.     
  87.     
  88.     
  89.     
  90.     // ** KEYWORDS
  91.     public static final String TEMPLATE_MAX_THREADS_THRESHOLD = "@CT_MAX_THREADS_THRESHOLD@"; // numero massimo di richieste simultanee configurate sul sistema
  92.     public static final String TEMPLATE_CONTROLLO_TRAFFICO_THRESHOLD = "@CT_THRESHOLD@"; // soglia in % che indica quando attivare il controllo del traffico
  93.     public static final String TEMPLATE_ACTIVE_THREADS = "@CT_ACTIVE_THREADS@"; // threads attivi
  94.     public static final String TEMPLATE_NUMERO_POLICY = "@CT_POLICIES@"; // numero di policy configurate
  95.     public static final String TEMPLATE_NUMERO_POLICY_DISABILITATE = "@CT_DISABLED_POLICIES@"; // numero di policy disabilitate
  96.     public static final String TEMPLATE_NUMERO_POLICY_FILTRATE = "@CT_FILTERED_POLICIES@"; // numero di policy filtrate
  97.     public static final String TEMPLATE_NUMERO_POLICY_NON_APPLICATE = "@CT_NOT_APPLICABLED_POLICIES@"; // numero di policy non applicabili
  98.     public static final String TEMPLATE_NUMERO_POLICY_RISPETTATE = "@CT_RESPECTED_POLICIES@"; // numero di policy rispettate
  99.     public static final String TEMPLATE_NUMERO_POLICY_VIOLATE = "@CT_VIOLATED_POLICIES@"; // numero di policy violate
  100.     public static final String TEMPLATE_NUMERO_POLICY_VIOLATE_WARNING_ONLY = "@CT_VIOLATED_WARNING_ONLY_POLICIES@"; // numero di policy violate in warning only mode
  101.     public static final String TEMPLATE_NUMERO_POLICY_IN_ERRORE = "@CT_ERROR_POLICIES@"; // numero di policy la cui verifica ha provocato un errore
  102.     
  103.     // ** KEYWORDS UTILIZZATE SOLAMENTE IN CONDIZIONI DI ERRORE O DEBUG
  104.     // sono i diagnostici emessi dai moduli ricezione contenuti o buste
  105.     public static final String TEMPLATE_POLICY_ACTIVE_ID = "@CT_POLICY_ACTIVE_ID@"; // identificativo della policy attivata
  106.     public static final String TEMPLATE_POLICY_ACTIVE_TIPO = "@CT_POLICY_ACTIVE_TIPO@"; // tipo della policy attivata (Globale/API)
  107.     public static final String TEMPLATE_POLICY_ACTIVE_ALIAS = "@CT_POLICY_ACTIVE_ALIAS@"; // alias della policy attivata
  108.     public static final String TEMPLATE_POLICY_ACTIVE_RISORSA = "@CT_POLICY_ACTIVE_RISORSA@"; // risorsa in fase di valutazione (es. NumeroRichieste, OccupazioneBanda...)
  109.     public static final String TEMPLATE_POLICY_ACTIVE_CONTINUE = "@CT_POLICY_ACTIVE_CONTINUE@"; //  true/false; indica se la valutazione delle policy per la stessa risorsa deve continuare o meno
  110.     public static final String TEMPLATE_POLICY_VIOLATA_MOTIVO = "@CT_POLICY_ERROR_MSG@"; // errore di violazione riscontrato sulla policy
  111.     public static final String TEMPLATE_POLICY_FILTRATA_MOTIVO = "@CT_POLICY_FILTERED_REASON@"; // motivo di filtro della policy
  112.     public static final String TEMPLATE_POLICY_NON_APPLICABILE_MOTIVO = "@CT_POLICY_NOT_APPLICABLED_REASON@"; // motivo della mancata applicabilità
  113.     
  114.     public static final String TEMPLATE_POLICY_FILTRATA_MOTIVO_FILTRO = "i dati della transazione non rispettano i criteri di filtro impostati: ";
  115.     public static final String TEMPLATE_POLICY_FILTRATA_MOTIVO_BREAK = "rilevata precedente policy soddisfatta";
  116.     public static final String TEMPLATE_POLICY_FILTRATA_MOTIVO_BREAK_VIOLATA = "rilevata precedente policy violata";
  117.     
  118.     // sono i diagnostici di "appoggio" registrati nel modulo 'all' utilizzati per generare l'errore
  119.     public static final String TEMPLATE_POLICY_VALORE_SOGLIA = "@CT_SOGLIA@"; // valore della soglia di una policy
  120.     public static final String TEMPLATE_POLICY_TIPOLOGIA_TEMPO_MEDIO = "@CT_TIPOLOGIA_TEMPO_MEDIO@"; // tipologia di tempo medio (servizio, totale...)
  121.     public static final String TEMPLATE_POLICY_VALORE_RILEVATO =  "@CT_RILEVATO@"; // contatore rilevato
  122.     public static final String TEMPLATE_POLICY_AVG_TIME_RILEVATO = "@CT_AVG_TIME_RILEVATO@"; // tempo medio rilevato
  123.     public static final String TEMPLATE_POLICY_VALORE_SOGLIA_DEGRADO_PRESTAZIONALE = "@CT_DEGRADO_SOGLIA@"; // valore di soglia per il degrado prestazionale
  124.     public static final String TEMPLATE_POLICY_GRUPPO = "@CT_DATI_IDENTIFICATIVI_GRUPPO@"; // raggruppamento
  125.     public static final String TEMPLATE_POLICY_INTERVALLO_TEMPORALE = "@CT_INTERVALLO_TEMPORALE@"; // intervallo temporale configurato
  126.     public static final String TEMPLATE_POLICY_NOME_ALLARME = "@CT_NOME_ALLARME@"; // nome dell'allarme utilizzata nelle condizioni di applicabilità
  127.     public static final String TEMPLATE_POLICY_STATO_ALLARME = "@CT_STATO_ALLARME@"; // stato dell'allarme
  128.     public static final String TEMPLATE_POLICY_STATO_ALLARME_ATTESO = "@CT_STATO_ALLARME_ATTESO@"; // stato dell'allarme atteso
  129.     

  131.     
  132.     private static final String SISTEMA_NON_DISPONIBILE = "Servizio Temporaneamente Non Erogabile";
  133.         
  134.     private static final String ERRORE_PROCESSAMENTO_CODE = "CC00";
  135.     private static final String MAX_THREADS_VIOLATED_CODE = "CC01";
  136.     
  137.     private static final String ERRORE_GENERICO_DURANTE_VERIFICA = "ERR-";
  138.     private static final String CONTROLLO_TRAFFICO_POLICY_VIOLATED_UNKNOW_TIPO = "CP00";
  139.     private static final String CONTROLLO_TRAFFICO_POLICY_VIOLATED_NUMERO_RICHIESTE_SIMULTANEE_CODE = "CP01";
  140.     private static final String CONTROLLO_TRAFFICO_POLICY_VIOLATED_NUMERO_RICHIESTE_CODE = "CP02";
  141.     private static final String CONTROLLO_TRAFFICO_POLICY_VIOLATED_OCCUPAZIONE_BANDA_CODE = "CP03";
  142.     private static final String CONTROLLO_TRAFFICO_POLICY_VIOLATED_TEMPO_COMPLESSIVO_CODE = "CP04";
  143.     private static final String CONTROLLO_TRAFFICO_POLICY_VIOLATED_TEMPO_MEDIO_CODE = "CP05";
  144.     private static final String CONTROLLO_TRAFFICO_POLICY_VIOLATED_NUMERO_RICHIESTE_COMPLETATE_CON_SUCCESSO_CODE = "CP06";
  145.     private static final String CONTROLLO_TRAFFICO_POLICY_VIOLATED_NUMERO_RICHIESTE_FALLITE_CODE = "CP07";
  146.     private static final String CONTROLLO_TRAFFICO_POLICY_VIOLATED_NUMERO_FAULT_APPLICATIVI_CODE = "CP08";
  147.     private static final String CONTROLLO_TRAFFICO_POLICY_VIOLATED_NUMERO_RICHIESTE_FALLITE_O_FAULT_APPLICATIVI_CODE = "CP09";
  148.     private static final String CONTROLLO_TRAFFICO_POLICY_VIOLATED_DIMENSIONE_MASSIMA_MESSAGGIO_CODE = "CP10";
  149.     private static final String CONTROLLO_TRAFFICO_POLICY_VIOLATED_NUMERO_RICHIESTE_COMPLETATE_CON_SUCCESSO_O_FAULT_APPLICATIVI_CODE = "CP11";
  150.     private static final String APPLICABILITA_CONGESTIONE_CODE = "-CC";
  151.     private static final String APPLICABILITA_DEGRADO_CODE = "-DP";
  152.     private static final String APPLICABILITA_STATO_ALLARME_CODE = "-SA";
  153.     
  154.     
  155.     
  156.     /* ***** EVENTI UTILI PER RICONOSCERE L'ESITO DELLA TRANSAZIONE ****** */
  157.     
  158.     public static final MapKey<String> PDD_CONTEXT_NAME_CONTROLLO_TRAFFICO_VIOLAZIONE = org.openspcoop2.core.controllo_traffico.constants.Costanti.PDD_CONTEXT_NAME_CONTROLLO_TRAFFICO_VIOLAZIONE;
  159.     
  160.     private static final String PDD_CONTEXT_VALUE_GENERIC_ERROR = "controlloTrafficoGenericError";
  161.     public static void addPddContextInfoControlloTrafficoGenericError(PdDContext pddContext){
  162.         pddContext.addObject(PDD_CONTEXT_NAME_CONTROLLO_TRAFFICO_VIOLAZIONE, PDD_CONTEXT_VALUE_GENERIC_ERROR);
  163.     }
  164.     
  165.     private static final String PDD_CONTEXT_VALUE_MAX_THREADS_VIOLATO = "controlloTrafficoNumeroMassimoRichiesteSimultaneeViolato";
  166.     private static final String PDD_CONTEXT_VALUE_MAX_THREADS_VIOLATO_WARNING_ONLY = "controlloTrafficoNumeroMassimoRichiesteSimultaneeViolatoWarningOnly";
  167.     public static void addPddContextInfoControlloTrafficoMaxThreadsViolated(PdDContext pddContext, boolean warningOnly){
  168.         if(warningOnly){
  169.             pddContext.addObject(PDD_CONTEXT_NAME_CONTROLLO_TRAFFICO_VIOLAZIONE, PDD_CONTEXT_VALUE_MAX_THREADS_VIOLATO_WARNING_ONLY);
  170.         }
  171.         else{
  172.             pddContext.addObject(PDD_CONTEXT_NAME_CONTROLLO_TRAFFICO_VIOLAZIONE, PDD_CONTEXT_VALUE_MAX_THREADS_VIOLATO);
  173.         }
  174.     }
  175.     
  176.     private static final String PDD_CONTEXT_VALUE_POLICY_VIOLATA = org.openspcoop2.core.controllo_traffico.constants.Costanti.PDD_CONTEXT_VALUE_POLICY_VIOLATA;
  177.     private static final String PDD_CONTEXT_VALUE_POLICY_VIOLATA_WARNING_ONLY = org.openspcoop2.core.controllo_traffico.constants.Costanti.PDD_CONTEXT_VALUE_POLICY_VIOLATA_WARNING_ONLY;
  178.     private static final String PDD_CONTEXT_VALUE_POLICY_IN_ERRORE = org.openspcoop2.core.controllo_traffico.constants.Costanti.PDD_CONTEXT_VALUE_POLICY_IN_ERRORE;
  179.     public static void addPddContextInfoControlloTrafficoPolicyViolated(PdDContext pddContext, boolean warningOnly){
  180.         addContextInfoControlloTrafficoPolicyViolated(pddContext, warningOnly);
  181.     }
  182.     public static void addContextInfoControlloTrafficoPolicyViolated(Context context, boolean warningOnly){
  183.         if(warningOnly){
  184.             context.addObject(PDD_CONTEXT_NAME_CONTROLLO_TRAFFICO_VIOLAZIONE, PDD_CONTEXT_VALUE_POLICY_VIOLATA_WARNING_ONLY);
  185.         }
  186.         else{
  187.             context.addObject(PDD_CONTEXT_NAME_CONTROLLO_TRAFFICO_VIOLAZIONE, PDD_CONTEXT_VALUE_POLICY_VIOLATA);
  188.         }
  189.     }
  190.     
  191.     public static void addPddContextInfoControlloTrafficoPolicyInError(PdDContext pddContext, EsitoTransazioneName esito){
  192.         pddContext.addObject(PDD_CONTEXT_NAME_CONTROLLO_TRAFFICO_VIOLAZIONE, PDD_CONTEXT_VALUE_POLICY_IN_ERRORE);
  193.         pddContext.addObject(org.openspcoop2.core.controllo_traffico.constants.Costanti.PDD_CONTEXT_VALUE_POLICY_IN_ERROR_ESITO, esito);
  194.     }
  195.     
  196.     public static final MapKey<String> PDD_CONTEXT_MAX_THREADS_THRESHOLD = Map.newMapKey("CT_MAX_THREADS_THRESHOLD"); // numero massimo di richieste simultanee configurate sul sistema
  197.     public static final MapKey<String> PDD_CONTEXT_CONTROLLO_TRAFFICO_THRESHOLD = Map.newMapKey("CT_THRESHOLD"); // soglia in % che indica quando attivare il controllo del traffico
  198.     
  199.     public static final MapKey<String> PDD_CONTEXT_ACTIVE_THREADS = Map.newMapKey("CT_ACTIVE_THREADS"); // threads attivi
  200.     public static final MapKey<String> PDD_CONTEXT_NUMERO_POLICY = Map.newMapKey("CT_POLICIES"); // numero di policy configurate
  201.     public static final MapKey<String> PDD_CONTEXT_NUMERO_POLICY_DISABILITATE = Map.newMapKey("CT_DISABLED_POLICIES"); // numero di policy disabilitate
  202.     public static final MapKey<String> PDD_CONTEXT_NUMERO_POLICY_FILTRATE = Map.newMapKey("CT_FILTERED_POLICIES"); // numero di policy filtrate
  203.     public static final MapKey<String> PDD_CONTEXT_NUMERO_POLICY_NON_APPLICATE = Map.newMapKey("CT_NOT_APPLICABLED_POLICIES"); // numero di policy non applicabili
  204.     public static final MapKey<String> PDD_CONTEXT_NUMERO_POLICY_RISPETTATE = Map.newMapKey("CT_RESPECTED_POLICIES"); // numero di policy rispettate
  205.     public static final MapKey<String> PDD_CONTEXT_NUMERO_POLICY_VIOLATE = Map.newMapKey("CT_VIOLATED_POLICIES"); // numero di policy violate
  206.     public static final MapKey<String> PDD_CONTEXT_NUMERO_POLICY_VIOLATE_WARNING_ONLY = Map.newMapKey("CT_VIOLATED_WARNING_ONLY_POLICIES"); // numero di policy violate in warning only mode
  207.     public static final MapKey<String> PDD_CONTEXT_NUMERO_POLICY_IN_ERRORE = Map.newMapKey("CT_ERROR_POLICIES"); // numero di policy la cui verifica ha provocato un errore
  208.     
  209.     private static final String PDD_CONTEXT_VALUE_CONNECTION_TIMEOUT = org.openspcoop2.core.controllo_traffico.constants.Costanti.PDD_CONTEXT_VALUE_CONNECTION_TIMEOUT;
  210.     private static final String PDD_CONTEXT_VALUE_REQUEST_READ_TIMEOUT = org.openspcoop2.core.controllo_traffico.constants.Costanti.PDD_CONTEXT_VALUE_REQUEST_READ_TIMEOUT;
  211.     private static final String PDD_CONTEXT_VALUE_RESPONSE_READ_TIMEOUT = org.openspcoop2.core.controllo_traffico.constants.Costanti.PDD_CONTEXT_VALUE_RESPONSE_READ_TIMEOUT;
  212.     private static final String PDD_CONTEXT_VALUE_READ_TIMEOUT = org.openspcoop2.core.controllo_traffico.constants.Costanti.PDD_CONTEXT_VALUE_READ_TIMEOUT;
  213.     public static boolean addPddContextInfoControlloTrafficoConnectionTimeout(Context pddContext){
  214.         if(alreadyExistsPddContextInfoControlloTrafficoTimeout(pddContext, PDD_CONTEXT_VALUE_CONNECTION_TIMEOUT)) {
  215.             return false;
  216.         }
  217.         pddContext.addObject(PDD_CONTEXT_NAME_CONTROLLO_TRAFFICO_VIOLAZIONE, PDD_CONTEXT_VALUE_CONNECTION_TIMEOUT);
  218.         return true;
  219.     }
  220.     public static boolean addPddContextInfoControlloTrafficoReadRequestTimeout(Context pddContext, boolean checkAll){
  221.         if(checkAll) {
  222.             if(alreadyExistsPddContextInfoControlloTrafficoTimeout(pddContext, 
  223.                     PDD_CONTEXT_VALUE_READ_TIMEOUT, PDD_CONTEXT_VALUE_RESPONSE_READ_TIMEOUT, PDD_CONTEXT_VALUE_REQUEST_READ_TIMEOUT)) {
  224.                 return false;
  225.             }
  226.         }
  227.         else if(alreadyExistsPddContextInfoControlloTrafficoTimeout(pddContext, PDD_CONTEXT_VALUE_REQUEST_READ_TIMEOUT)) {
  228.             return false;
  229.         }
  230.         pddContext.addObject(PDD_CONTEXT_NAME_CONTROLLO_TRAFFICO_VIOLAZIONE, PDD_CONTEXT_VALUE_REQUEST_READ_TIMEOUT);
  231.         return true;
  232.     }
  233.     public static boolean addPddContextInfoControlloTrafficoReadResponseTimeout(Context pddContext, boolean checkAll){
  234.         if(checkAll) {
  235.             if(alreadyExistsPddContextInfoControlloTrafficoTimeout(pddContext, 
  236.                     PDD_CONTEXT_VALUE_READ_TIMEOUT, PDD_CONTEXT_VALUE_RESPONSE_READ_TIMEOUT, PDD_CONTEXT_VALUE_REQUEST_READ_TIMEOUT)) {
  237.                 return false;
  238.             }
  239.         }
  240.         else if(alreadyExistsPddContextInfoControlloTrafficoTimeout(pddContext, PDD_CONTEXT_VALUE_RESPONSE_READ_TIMEOUT)) {
  241.             return false;
  242.         }
  243.         pddContext.addObject(PDD_CONTEXT_NAME_CONTROLLO_TRAFFICO_VIOLAZIONE, PDD_CONTEXT_VALUE_RESPONSE_READ_TIMEOUT);
  244.         return true;
  245.     }
  246.     public static boolean addPddContextInfoControlloTrafficoReadTimeout(Context pddContext, boolean checkAll){
  247.         if(checkAll) {
  248.             if(alreadyExistsPddContextInfoControlloTrafficoTimeout(pddContext, 
  249.                     PDD_CONTEXT_VALUE_READ_TIMEOUT, PDD_CONTEXT_VALUE_RESPONSE_READ_TIMEOUT, PDD_CONTEXT_VALUE_REQUEST_READ_TIMEOUT)) {
  250.                 return false;
  251.             }
  252.         }
  253.         else if(alreadyExistsPddContextInfoControlloTrafficoTimeout(pddContext, PDD_CONTEXT_VALUE_READ_TIMEOUT)) {
  254.             return false;
  255.         }
  256.         pddContext.addObject(PDD_CONTEXT_NAME_CONTROLLO_TRAFFICO_VIOLAZIONE, PDD_CONTEXT_VALUE_READ_TIMEOUT);
  257.         return true;
  258.     }
  259.     private static boolean alreadyExistsPddContextInfoControlloTrafficoTimeout(Context pddContext, String ... valore) {
  260.         if(valore!=null && valore.length>0) {
  261.             for (String v : valore) {
  262.                 if(alreadyExistsPddContextInfoControlloTrafficoTimeout(pddContext, v)) {
  263.                     return true;
  264.                 }
  265.             }
  266.         }
  267.         return false;
  268.     }
  269.     private static boolean alreadyExistsPddContextInfoControlloTrafficoTimeout(Context pddContext, String valore) {
  270.         if(pddContext.containsKey(PDD_CONTEXT_NAME_CONTROLLO_TRAFFICO_VIOLAZIONE)) {
  271.             String tipo = (String) pddContext.get(PDD_CONTEXT_NAME_CONTROLLO_TRAFFICO_VIOLAZIONE);
  272.             if(tipo!=null) {
  273.                 return valore.equals(tipo);
  274.             }
  275.         }
  276.         return false;
  277.     }
  278.     
  279.     /* ***** FAULT ****** */
  280.     
  281.     public static HandlerException getErroreProcessamento(Exception e, 
  282.             PdDContext pddContext){
  283.                 
  284.         if(pddContext!=null) {
  285.             // nop
  286.         }
  287.         
  288.         HandlerException he = new HandlerException( SISTEMA_NON_DISPONIBILE + " [" + ERRORE_PROCESSAMENTO_CODE + "]" , e);
  289.         he.setCustomizedResponse(true);
  290.         he.setCustomizedResponseAs4xxCode(false);
  291.         he.setCustomizedResponseCode(ERRORE_PROCESSAMENTO_CODE);
  292.         
  293.         return he;

  295.     } 
  296.     
  297.     public static HandlerException getMaxThreadsViolated(String messaggioErroreInChiaro, boolean erroreGenerico, 
  298.             PdDContext pddContext){
  299.         
  300.         if(pddContext!=null) {
  301.             // nop
  302.         }
  303.         
  304.         HandlerException he =  null;
  305.         
  306.         if(erroreGenerico){
  307.             he = new HandlerException( SISTEMA_NON_DISPONIBILE + " [" + MAX_THREADS_VIOLATED_CODE + "]" );
  308.         }
  309.         else{
  310.             he = new HandlerException( messaggioErroreInChiaro );
  311.         }
  312.         
  313.         he.setCustomizedResponse(true);
  314.         he.setCustomizedResponseAs4xxCode(true);
  315.         he.setCustomizedResponseCode(MAX_THREADS_VIOLATED_CODE);
  316.         he.setIntegrationFunctionError(IntegrationFunctionError.TOO_MANY_REQUESTS);
  317.                         
  318.         return he;
  319.     } 
  320.     
  321.     public static HandlerException getControlloTrafficoPolicyViolated(List<RisultatoVerificaPolicy> policyViolate, boolean erroreGenerico, 
  322.             PdDContext pddContext){
  323.         
  324.         if(pddContext!=null) {
  325.             // nop
  326.         }
  327.         
  328.         HandlerException he =  null;
  329.         
  330.         StringBuilder bf = new StringBuilder();
  331.         if(!erroreGenerico){
  332.             bf.append("Rilevate "+policyViolate.size()+" policy violate:\n");
  333.         }
  334.         boolean limitExceededConditionalCongestion = false; 
  335.         boolean limitExceededConditionalDeteriorationPerformance = false; 
  336.         boolean limitExceeded = false; 
  337.         boolean tooManyRequestsConditionalCongestion = false; 
  338.         boolean tooManyRequestsConditionalDeteriorationPerformance = false; 
  339.         boolean tooManyRequests = false; 
  340.                 
  341.         for (int i = 0; i < policyViolate.size(); i++) {
  342.             RisultatoVerificaPolicy risultato = policyViolate.get(i);
  343.             
  344.             if(!risultato.isErroreGenerico()) {
  345.                 if(risultato.isSimultanee()) {
  346.                     if(risultato.isApplicabilitaCongestione()) {
  347.                         tooManyRequestsConditionalCongestion = true;
  348.                     }
  349.                     else if(risultato.isApplicabilitaDegradoPrestazionale()) {
  350.                         tooManyRequestsConditionalDeteriorationPerformance = true;
  351.                     }
  352.                     else if(risultato.isApplicabilitaStatoAllarme()) {
  353.                         tooManyRequestsConditionalDeteriorationPerformance = true; // fare IntegrationFunctionError apposito
  354.                     }
  355.                     else {
  356.                         tooManyRequests = true;
  357.                     }
  358.                 }
  359.                 else {
  360.                     if(risultato.isApplicabilitaCongestione()) {
  361.                         limitExceededConditionalCongestion = true;
  362.                     }
  363.                     else if(risultato.isApplicabilitaDegradoPrestazionale()) {
  364.                         limitExceededConditionalDeteriorationPerformance = true;
  365.                     }
  366.                     else if(risultato.isApplicabilitaStatoAllarme()) {
  367.                         limitExceededConditionalDeteriorationPerformance = true; // fare IntegrationFunctionError apposito
  368.                     }
  369.                     else {
  370.                         limitExceeded = true;
  371.                     }
  372.                 }
  373.             }
  374.             else {
  375.                 tooManyRequests = true; // viene scelto questo 
  376.             }
  377.             
  378.             if(erroreGenerico){
  379.                 
  380.                 if(i>0){
  381.                     bf.append(",");
  382.                 }
  383.                 
  384.                 bf.append(toCode(risultato));
  385.                 
  386.             }
  387.             else{
  388.                 
  389.                 if(i>0){
  390.                     bf.append("\n");
  391.                 }
  392.                 
  393.                 if(risultato.isErroreGenerico()){
  394.                     bf.append("\tPolicy-"+(i+1)+" (Errore interno) "+risultato.getDescrizione());
  395.                 }
  396.                 else{
  397.                     bf.append("\tPolicy-"+(i+1)+" (Violata) "+risultato.getDescrizione());
  398.                 }
  399.             }
  400.         }
  401.         
  402.         if(erroreGenerico){
  403.             he = new HandlerException( SISTEMA_NON_DISPONIBILE + " [" + bf.toString() + "]" );
  404.         }
  405.         else{
  406.             he = new HandlerException( bf.toString() );
  407.         }
  408.         
  409.         he.setCustomizedResponse(true);
  410.         he.setCustomizedResponseAs4xxCode(true);
  411.         StringBuilder bfCode = new StringBuilder();
  412.         for (int i = 0; i < policyViolate.size(); i++) {
  413.             RisultatoVerificaPolicy risultato = policyViolate.get(i);
  414.             if(i>0){
  415.                 bfCode.append("_");
  416.             }
  417.             bfCode.append(toCode(risultato));
  418.         }
  419.         he.setCustomizedResponseCode(bfCode.toString());
  420.         
  421.         if(limitExceeded) {
  422.             // prevale poiche' il client non potra rispedire
  423.             he.setIntegrationFunctionError(IntegrationFunctionError.LIMIT_EXCEEDED);
  424.         }
  425.         else if(limitExceededConditionalCongestion) {
  426.             he.setIntegrationFunctionError(IntegrationFunctionError.LIMIT_EXCEEDED_CONDITIONAL_CONGESTION);
  427.         }
  428.         else if(limitExceededConditionalDeteriorationPerformance) {
  429.             he.setIntegrationFunctionError(IntegrationFunctionError.LIMIT_EXCEEDED_CONDITIONAL_DETERIORATION_PERFORMANCE);
  430.         }
  431.         else if(tooManyRequests) {
  432.             he.setIntegrationFunctionError(IntegrationFunctionError.TOO_MANY_REQUESTS);
  433.         }
  434.         else if(tooManyRequestsConditionalCongestion) {
  435.             he.setIntegrationFunctionError(IntegrationFunctionError.TOO_MANY_REQUESTS_CONDITIONAL_CONGESTION);
  436.         }
  437.         else if(tooManyRequestsConditionalDeteriorationPerformance) {
  438.             he.setIntegrationFunctionError(IntegrationFunctionError.TOO_MANY_REQUESTS_CONDITIONAL_DETERIORATION_PERFORMANCE);
  439.         }
  440.         else {
  441.             he.setIntegrationFunctionError(IntegrationFunctionError.TOO_MANY_REQUESTS);
  442.         }
  443.         
  444.         return he;
  445.     } 

  447.     private static String toCode(RisultatoVerificaPolicy risultato) {
  448.         StringBuilder bf = new StringBuilder();
  449.         if(risultato.isErroreGenerico()){
  450.             bf.append(ERRORE_GENERICO_DURANTE_VERIFICA);
  451.         }
  452.         
  453.         if(risultato.getRisorsa()==null){
  454.             bf.append(CONTROLLO_TRAFFICO_POLICY_VIOLATED_UNKNOW_TIPO);
  455.         }
  456.         else{
  457.             switch (risultato.getRisorsa()) {
  458.             case NUMERO_RICHIESTE:
  459.                 if(risultato.isSimultanee()){
  460.                     bf.append(CONTROLLO_TRAFFICO_POLICY_VIOLATED_NUMERO_RICHIESTE_SIMULTANEE_CODE);
  461.                 }
  462.                 else{
  463.                     bf.append(CONTROLLO_TRAFFICO_POLICY_VIOLATED_NUMERO_RICHIESTE_CODE);
  464.                 }
  465.                 break;
  466.             case DIMENSIONE_MASSIMA_MESSAGGIO:
  467.                 bf.append(CONTROLLO_TRAFFICO_POLICY_VIOLATED_DIMENSIONE_MASSIMA_MESSAGGIO_CODE);
  468.                 break;
  469.             case OCCUPAZIONE_BANDA:
  470.                 bf.append(CONTROLLO_TRAFFICO_POLICY_VIOLATED_OCCUPAZIONE_BANDA_CODE);
  471.                 break;
  472.             case TEMPO_COMPLESSIVO_RISPOSTA:
  473.                 bf.append(CONTROLLO_TRAFFICO_POLICY_VIOLATED_TEMPO_COMPLESSIVO_CODE);
  474.                 break;
  475.             case TEMPO_MEDIO_RISPOSTA:
  476.                 bf.append(CONTROLLO_TRAFFICO_POLICY_VIOLATED_TEMPO_MEDIO_CODE);
  477.                 break;
  478.             case NUMERO_RICHIESTE_COMPLETATE_CON_SUCCESSO:
  479.                 bf.append(CONTROLLO_TRAFFICO_POLICY_VIOLATED_NUMERO_RICHIESTE_COMPLETATE_CON_SUCCESSO_CODE);
  480.                 break;
  481.             case NUMERO_RICHIESTE_FALLITE:
  482.                 bf.append(CONTROLLO_TRAFFICO_POLICY_VIOLATED_NUMERO_RICHIESTE_FALLITE_CODE);
  483.                 break;
  484.             case NUMERO_FAULT_APPLICATIVI:
  485.                 bf.append(CONTROLLO_TRAFFICO_POLICY_VIOLATED_NUMERO_FAULT_APPLICATIVI_CODE);
  486.                 break;
  487.             case NUMERO_RICHIESTE_FALLITE_OFAULT_APPLICATIVI:
  488.                 bf.append(CONTROLLO_TRAFFICO_POLICY_VIOLATED_NUMERO_RICHIESTE_FALLITE_O_FAULT_APPLICATIVI_CODE);
  489.                 break;
  490.             case NUMERO_RICHIESTE_COMPLETATE_CON_SUCCESSO_OFAULT_APPLICATIVI:
  491.                 bf.append(CONTROLLO_TRAFFICO_POLICY_VIOLATED_NUMERO_RICHIESTE_COMPLETATE_CON_SUCCESSO_O_FAULT_APPLICATIVI_CODE);
  492.                 break;
  493.             }
  494.             
  495.             if(risultato.isApplicabilitaCongestione()){
  496.                 bf.append(APPLICABILITA_CONGESTIONE_CODE);
  497.             }
  498.             if(risultato.isApplicabilitaDegradoPrestazionale()){
  499.                 bf.append(APPLICABILITA_DEGRADO_CODE);
  500.             }
  501.             if(risultato.isApplicabilitaStatoAllarme()){
  502.                 bf.append(APPLICABILITA_STATO_ALLARME_CODE);
  503.             }
  504.         }
  505.         return bf.toString();
  506.     }
  507.     
  508.     public static void configureHandlerExceptionByTipoErrore(ServiceBinding serviceBinding, HandlerException he, TipoErrore tipoErroreParam,boolean includiDescrizioneErrore,Logger log) throws ProtocolException {

  510.         TipoErrore tipoErrore = tipoErroreParam;
  511.         if(ServiceBinding.REST.equals(serviceBinding)) {
  512.             tipoErrore = TipoErrore.FAULT; // in rest il codice http viene auto-gestito correttamente
  513.         }
  514.         
  515.         if(he==null) {
  516.             throw new ProtocolException("HandlerException is null");
  517.         }
  518.         
  519.         switch (tipoErrore) {
  520.         case HTTP_429:
  521.             if(includiDescrizioneErrore) {
  522.                 he.setResponseContentType(HttpConstants.CONTENT_TYPE_HTML);
  523.                 
  524.                 String tipo = null;
  525.                 if(he.getIntegrationFunctionError()!=null) {
  526.                     switch (he.getIntegrationFunctionError()) {
  527.                     case LIMIT_EXCEEDED:
  528.                     case LIMIT_EXCEEDED_CONDITIONAL_CONGESTION:
  529.                     case LIMIT_EXCEEDED_CONDITIONAL_DETERIORATION_PERFORMANCE:
  530.                         tipo = CostantiControlloTraffico.HTML_429_LIMIT_EXCEEDED_ERROR;
  531.                         break;
  532.                     case TOO_MANY_REQUESTS:
  533.                     case TOO_MANY_REQUESTS_CONDITIONAL_CONGESTION:
  534.                     case TOO_MANY_REQUESTS_CONDITIONAL_DETERIORATION_PERFORMANCE:
  535.                         tipo = CostantiControlloTraffico.HTML_429_TOO_MANY_REQUESTS_ERROR;
  536.                         break;
  537.                     default:
  538.                         tipo = CostantiControlloTraffico.HTML_429_TOO_MANY_REQUESTS_ERROR;
  539.                         break;
  540.                     }
  541.                 }
  542.                 else {
  543.                     tipo = CostantiControlloTraffico.HTML_429_TOO_MANY_REQUESTS_ERROR;
  544.                 }
  545.                 
  546.                 String msgErrore = null;
  547.                 ErroriProperties erroriProperties = ErroriProperties.getInstance(log);
  548.                 boolean genericDetails = true;
  549.                 IntegrationFunctionError functionError = IntegrationFunctionError.TOO_MANY_REQUESTS;
  550.                 if(he.getIntegrationFunctionError()!=null) {
  551.                     functionError = he.getIntegrationFunctionError();
  552.                 }
  553.                 /**if(!genericDetails && erroriProperties.isForceGenericDetails(functionError)) {
  554.                     genericDetails = true;
  555.                 }*/
  556.                 if (Costanti.isTRANSACTION_FORCE_SPECIFIC_ERROR_DETAILS()) {
  557.                     genericDetails = false;
  558.                 }
  559.                 if(!genericDetails) {
  560.                     msgErrore = he.getMessage();
  561.                 }
  562.                 else {
  563.                     msgErrore = erroriProperties.getGenericDetails(functionError);
  564.                 }
  565.                 
  566.                 String html = tipo
  567.                         .replace(CostantiControlloTraffico.HTML_ERROR_MESSAGE_TEMPLATE, msgErrore);
  568.                 he.setResponse(html.getBytes());
  569.             }
  570.             else {
  571.                 he.setEmptyResponse(true);
  572.             }
  573.             he.setResponseCode("429");
  574.             break;
  575.         case HTTP_503:
  576.             if(includiDescrizioneErrore) {
  577.                 he.setResponseContentType(HttpConstants.CONTENT_TYPE_HTML);
  578.                 String html = CostantiControlloTraffico.HTML_503_ERROR
  579.                         .replace(CostantiControlloTraffico.HTML_ERROR_MESSAGE_TEMPLATE, he.getMessage());
  580.                 he.setResponse(html.getBytes());
  581.             }
  582.             else {
  583.                 he.setEmptyResponse(true);
  584.             }
  585.             he.setResponseCode("503");
  586.             break;
  587.         case HTTP_500:
  588.             if(includiDescrizioneErrore) {
  589.                 he.setResponseContentType(HttpConstants.CONTENT_TYPE_HTML);
  590.                 String html = CostantiControlloTraffico.HTML_500_ERROR
  591.                         .replace(CostantiControlloTraffico.HTML_ERROR_MESSAGE_TEMPLATE, he.getMessage());
  592.                 he.setResponse(html.getBytes());
  593.             }
  594.             else {
  595.                 he.setEmptyResponse(true);
  596.             }
  597.             he.setResponseCode("500");
  598.             break;
  599.         case FAULT:
  600.             if(!includiDescrizioneErrore) {
  601.                 he.setCustomizedResponse(false);
  602.             }
  603.             break;
  604.         }
  605.     }
  606.     
  607. }
Created with JaCoCo 0.8.8.202204050719