DimensioneMessaggiConfigurationUtils.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.HashMap;
  24. import java.util.Iterator;
  25. import java.util.List;
  26. import java.util.Map;

  28. import org.apache.commons.lang.StringUtils;
  29. import org.openspcoop2.core.commons.CoreException;
  30. import org.openspcoop2.core.config.PortaApplicativa;
  31. import org.openspcoop2.core.config.PortaDelegata;
  32. import org.openspcoop2.core.config.Proprieta;
  33. import org.openspcoop2.core.config.driver.DriverConfigurazioneException;
  34. import org.openspcoop2.core.config.driver.DriverConfigurazioneNotFound;
  35. import org.openspcoop2.core.constants.TipoPdD;
  36. import org.openspcoop2.core.controllo_traffico.AttivazionePolicy;
  37. import org.openspcoop2.core.controllo_traffico.ConfigurazionePolicy;
  38. import org.openspcoop2.core.controllo_traffico.ElencoIdPolicyAttive;
  39. import org.openspcoop2.core.controllo_traffico.IdActivePolicy;
  40. import org.openspcoop2.core.controllo_traffico.beans.DatiTransazione;
  41. import org.openspcoop2.core.controllo_traffico.beans.UniqueIdentifierUtilities;
  42. import org.openspcoop2.core.controllo_traffico.constants.TipoRisorsaPolicyAttiva;
  43. import org.openspcoop2.core.controllo_traffico.utils.PolicyUtilities;
  44. import org.openspcoop2.core.id.IDPortaApplicativa;
  45. import org.openspcoop2.core.id.IDPortaDelegata;
  46. import org.openspcoop2.message.OpenSPCoop2Message;
  47. import org.openspcoop2.pdd.config.ConfigurazionePdDManager;
  48. import org.openspcoop2.pdd.config.CostantiProprieta;
  49. import org.openspcoop2.pdd.config.OpenSPCoop2Properties;
  50. import org.openspcoop2.pdd.core.PdDContext;
  51. import org.openspcoop2.pdd.core.controllo_traffico.policy.InterceptorPolicyUtilities;
  52. import org.openspcoop2.pdd.core.controllo_traffico.policy.PolicyFiltroApplicativoUtilities;
  53. import org.openspcoop2.pdd.core.controllo_traffico.policy.PolicyVerifier;
  54. import org.openspcoop2.protocol.sdk.IProtocolFactory;
  55. import org.openspcoop2.protocol.sdk.ProtocolException;
  56. import org.openspcoop2.protocol.sdk.state.RequestInfo;
  57. import org.openspcoop2.protocol.sdk.state.URLProtocolContext;
  58. import org.slf4j.Logger;

  60. /**     
  61.  * DimensioneMessaggiConfigurationUtils
  62.  *
  63.  * @author Poli Andrea (poli@link.it)
  64.  * @author $Author$
  65.  * @version $Rev$, $Date$
  66.  */
  67. public class DimensioneMessaggiConfigurationUtils {

  69.     private DimensioneMessaggiConfigurationUtils() {}
  70.     
  71.     private static void logDebug(Logger log, String msg) {
  72.         if(log!=null) {
  73.             log.debug(msg);
  74.         }
  75.     }
  76.     
  77.     public static SoglieDimensioneMessaggi readSoglieDimensioneMessaggi(TipoPdD tipoPdD, String nomePorta, 
  78.             DatiTransazione datiTransazione, Logger log,
  79.             URLProtocolContext urlProtocolContext, RequestInfo requestInfo, PdDContext pddContext,
  80.             IProtocolFactory<?> protocolFactory) throws CoreException {
  81.         
  82.         OpenSPCoop2Properties op2Properties = OpenSPCoop2Properties.getInstance();
  83.         ConfigurazioneGatewayControlloTraffico configurazioneControlloTraffico =  op2Properties.getConfigurazioneControlloTraffico();
  84.         ConfigurazionePdDManager configPdDManager = ConfigurazionePdDManager.getInstance();
  85.         
  86.         SoglieDimensioneMessaggi soglie = null;
  87.         
  88.         Map<TipoRisorsaPolicyAttiva, ElencoIdPolicyAttive> mapPolicyAttive = null;
  89.         boolean mapFromRequestInfo = false;
  90.         try{
  91.         
  92.             if(requestInfo!=null && requestInfo.getRequestRateLimitingConfig()!=null) {
  93.                 if(requestInfo.getRequestRateLimitingConfig().getNomePorta()==null && nomePorta!=null) {
  94.                     requestInfo.getRequestRateLimitingConfig().setDatiPorta(tipoPdD, nomePorta, 
  95.                             datiTransazione!=null ? datiTransazione.getIdServizio() :  null,
  96.                             datiTransazione!=null ? datiTransazione.getSoggettoFruitore() : null);
  97.                 }
  98.                 if(requestInfo.getRequestRateLimitingConfig().getMapPolicyAttive_dimensioneMessaggi()!=null) {
  99.                     mapPolicyAttive = requestInfo.getRequestRateLimitingConfig().getMapPolicyAttive_dimensioneMessaggi();
  100.                     mapFromRequestInfo = true;
  101.                 }
  102.             }
  103.             
  104.             if(!mapFromRequestInfo) {
  105.                 
  106.                 mapPolicyAttive = new HashMap<>();
  107.                 
  108.                 if(tipoPdD!=null && nomePorta!=null) {
  109.                     Map<TipoRisorsaPolicyAttiva, ElencoIdPolicyAttive> mapPolicyAttiveAPI = null;
  110.                     try {
  111.                         mapPolicyAttiveAPI = configPdDManager.getElencoIdPolicyAttiveAPIDimensioneMessaggio(configurazioneControlloTraffico.isPolicyReadedWithDynamicCache(),
  112.                                 tipoPdD, nomePorta);
  113.                     }catch(DriverConfigurazioneNotFound notFound) {
  114.                         // ignore
  115.                     }
  116.                     if(mapPolicyAttiveAPI!=null && !mapPolicyAttiveAPI.isEmpty()) {
  117.                         Iterator<TipoRisorsaPolicyAttiva> it = mapPolicyAttiveAPI.keySet().iterator();
  118.                         while (it.hasNext()) {
  119.                             TipoRisorsaPolicyAttiva tipoRisorsaPolicyAttiva = it.next();
  120.                             ElencoIdPolicyAttive elencoPolicyAttiveAPI = mapPolicyAttiveAPI.get(tipoRisorsaPolicyAttiva);
  121.                             if(elencoPolicyAttiveAPI!=null) {
  122.                                 ElencoIdPolicyAttive cloned = (ElencoIdPolicyAttive) elencoPolicyAttiveAPI.clone(); // altrimenti dopo aggiungendo quelle globali si modifica l'oggetto in cache
  123.                                 mapPolicyAttive.put(tipoRisorsaPolicyAttiva, cloned);
  124.                             }
  125.                         }
  126.                     }
  127.                 }
  128.         
  129.                 Map<TipoRisorsaPolicyAttiva, ElencoIdPolicyAttive> mapPolicyAttiveGlobali = null;
  130.                 try {
  131.                     mapPolicyAttiveGlobali = configPdDManager.getElencoIdPolicyAttiveGlobaliDimensioneMessaggio(configurazioneControlloTraffico.isPolicyReadedWithDynamicCache());
  132.                 }catch(DriverConfigurazioneNotFound notFound) {
  133.                     // ignore
  134.                 }
  135.                 if(mapPolicyAttiveGlobali!=null && !mapPolicyAttiveGlobali.isEmpty()) {
  136.                     Iterator<TipoRisorsaPolicyAttiva> it = mapPolicyAttiveGlobali.keySet().iterator();
  137.                     while (it.hasNext()) {
  138.                         TipoRisorsaPolicyAttiva tipoRisorsaPolicyAttiva = it.next();
  139.                         ElencoIdPolicyAttive elencoPolicyAttiveGlobali = mapPolicyAttiveGlobali.get(tipoRisorsaPolicyAttiva);
  140.                         
  141.                         if(mapPolicyAttive.containsKey(tipoRisorsaPolicyAttiva)) {
  142.                             ElencoIdPolicyAttive elencoPolicyAttiveCloned = mapPolicyAttive.get(tipoRisorsaPolicyAttiva); // gia' clonato per l'api sopra
  143.                             for (IdActivePolicy idActivePolicyGlobale : elencoPolicyAttiveGlobali.getIdActivePolicyList()) {
  144.                                 elencoPolicyAttiveCloned.addIdActivePolicy(idActivePolicyGlobale);
  145.                             }
  146.                         }
  147.                         else {
  148.                             ElencoIdPolicyAttive cloned = (ElencoIdPolicyAttive) elencoPolicyAttiveGlobali.clone(); // per non modificare l'oggetto in cache
  149.                             mapPolicyAttive.put(tipoRisorsaPolicyAttiva, cloned);
  150.                         }
  151.                     }
  152.                 }
  153.                 
  154.                 if(requestInfo!=null && requestInfo.getRequestRateLimitingConfig()!=null) {
  155.                     requestInfo.getRequestRateLimitingConfig().setMapPolicyAttive_dimensioneMessaggi(mapPolicyAttive);
  156.                 }
  157.             }
  158.         }catch(Exception e){
  159.             throw new CoreException("Configurazione non disponibile: "+e.getMessage(), e);
  160.         }
  161.         
  162.         try{
  163.             if(mapPolicyAttive!=null && !mapPolicyAttive.isEmpty()){
  164.                 
  165.                 int policyTotali = 0;
  166.                 int policyDisabilitate = 0;
  167.                 int policyFiltrate = 0;
  168.                 /**int policyNonApplicabili = 0;*/
  169.                 int policyRispettate = 0;
  170.                 /**int policyViolate = 0;*/
  171.                 /**int policyViolateWarningOnly = 0;*/
  172.                 int policyInErrore = 0;
  173.                 
  174.                 Iterator<TipoRisorsaPolicyAttiva> it = mapPolicyAttive.keySet().iterator();
  175.                 while (it.hasNext()) {
  176.                     TipoRisorsaPolicyAttiva tipoRisorsaPolicyAttiva = it.next();
  177.                     
  178.                     if(!TipoRisorsaPolicyAttiva.DIMENSIONE_MASSIMA_MESSAGGIO.equals(tipoRisorsaPolicyAttiva)) {
  179.                         // non dovrebbe capitare mai
  180.                         continue;
  181.                     }
  182.                     
  183.                     ElencoIdPolicyAttive elencoPolicyAttivePerRisorsa = mapPolicyAttive.get(tipoRisorsaPolicyAttiva);
  184.                     
  185.                     boolean policyRispettataCheRichiedeBreak = false;
  186.                     boolean policyViolataBreak = false;
  187.                                         
  188.                     for (IdActivePolicy idActive : elencoPolicyAttivePerRisorsa.getIdActivePolicyList()) {
  189.                         
  190.                         policyTotali++;
  191.                         
  192.                         try{
  193.                             
  194.                             if(idActive.isEnabled()){
  195.                             
  196.                                 // Prelevo la configurazione del Controllo del Traffico per quanto concerne le policy attive
  197.                                 AttivazionePolicy attivazionePolicy = null;
  198.                                 try {
  199.                                     String id = UniqueIdentifierUtilities.getUniqueId(idActive);
  200.                                     if(mapFromRequestInfo) {
  201.                                         attivazionePolicy = requestInfo.getRequestRateLimitingConfig().getAttivazionePolicy_dimensioneMessaggi(id);
  202.                                     }
  203.                                     if(attivazionePolicy==null) {
  204.                                         attivazionePolicy = configPdDManager.getAttivazionePolicy(configurazioneControlloTraffico.isPolicyReadedWithDynamicCache(), id);
  205.                                         if(requestInfo!=null && requestInfo.getRequestRateLimitingConfig()!=null) {
  206.                                             requestInfo.getRequestRateLimitingConfig().addAttivazionePolicy_dimensioneMessaggi(id, attivazionePolicy);
  207.                                         }
  208.                                     }
  209.                                 }catch(DriverConfigurazioneNotFound notFound) {
  210.                                     throw new CoreException("Istanza di Policy con id ["+idActive.getNome()+"] non esistente: "+notFound.getMessage(),notFound);
  211.                                 }
  212.                                 if(attivazionePolicy==null){
  213.                                     throw new CoreException("Istanza di Policy con id ["+idActive.getNome()+"] non esistente?");
  214.                                 }
  215.                                 String alias = PolicyUtilities.getNomeActivePolicy(attivazionePolicy.getAlias(), attivazionePolicy.getIdActivePolicy());
  216.                                 
  217.                                 // Verifico se un eventuale filtro configurato per la policy matcha con i dati della transazione
  218.                                 boolean matchFiltro = !policyRispettataCheRichiedeBreak && !policyViolataBreak && InterceptorPolicyUtilities.filter(attivazionePolicy.getFiltro(), datiTransazione, null, requestInfo);
  219.                                 if(matchFiltro){
  220.                                     
  221.                                     if(attivazionePolicy.getFiltro().isEnabled() && attivazionePolicy.getFiltro().isInformazioneApplicativaEnabled()){
  222.                                     
  223.                                         // Verifico Filtro Applicativo
  224.                                         OpenSPCoop2Message message = null;
  225.                                         String soapActionParam = null;
  226.                                         String valorePresente = PolicyFiltroApplicativoUtilities.getValore(log,
  227.                                                 attivazionePolicy.getFiltro().getInformazioneApplicativaTipo(), 
  228.                                                 attivazionePolicy.getFiltro().getInformazioneApplicativaNome(), 
  229.                                                 datiTransazione, true,
  230.                                                 message, urlProtocolContext, soapActionParam, pddContext,
  231.                                                 null);

  233.                                         if(valorePresente==null || !valorePresente.equals(attivazionePolicy.getFiltro().getInformazioneApplicativaValore())){
  234.                                             
  235.                                             policyFiltrate++;
  236.                                             
  237.                                             // Emetto Diagnostico Policy Filtrata
  238.                                             if(valorePresente==null){
  239.                                                 valorePresente = "n.d.";
  240.                                             }
  241.                                             logDebug(log,"Filtro Applicativo atteso ["+
  242.                                                     attivazionePolicy.getFiltro().getInformazioneApplicativaValore()+"] differente da quello estratto dalla transazione ["+
  243.                                                     valorePresente+"]");
  244.                                             
  245.                                             matchFiltro = false;
  246.                                             
  247.                                         }
  248.                                         
  249.                                     }
  250.                                     
  251.                                     if(matchFiltro){
  252.                                             
  253.                                         if(soglie==null) {
  254.                                             soglie = new SoglieDimensioneMessaggi();
  255.                                         }
  256.                                         long sogliaRichiesta = -1;
  257.                                         long sogliaRisposta = -1;
  258.                                         if(attivazionePolicy.isRidefinisci()) {
  259.                                             if(attivazionePolicy.getValore2()!=null) {
  260.                                                 sogliaRichiesta = attivazionePolicy.getValore2();
  261.                                             }
  262.                                             if(attivazionePolicy.getValore()!=null) {
  263.                                                 sogliaRisposta = attivazionePolicy.getValore();
  264.                                             }
  265.                                         }
  266.                                         else {
  267.                                         
  268.                                             // Prelevo la configurazione del Controllo del Traffico per quanto concerne le policy istanziata
  269.                                             ConfigurazionePolicy configurazionePolicy = null;
  270.                                             try {
  271.                                                 String id = idActive.getIdPolicy();
  272.                                                 if(mapFromRequestInfo) {
  273.                                                     configurazionePolicy = requestInfo.getRequestRateLimitingConfig().getConfigurazionePolicy_dimensioneMessaggi(id);
  274.                                                 }
  275.                                                 if(configurazionePolicy==null) {
  276.                                                     configurazionePolicy = configPdDManager.getConfigurazionePolicy(configurazioneControlloTraffico.isPolicyReadedWithDynamicCache(), id);
  277.                                                     if(requestInfo!=null && requestInfo.getRequestRateLimitingConfig()!=null) {
  278.                                                         requestInfo.getRequestRateLimitingConfig().addConfigurazionePolicy_dimensioneMessaggi(id, configurazionePolicy);
  279.                                                     }
  280.                                                 }
  281.                                             }catch(DriverConfigurazioneNotFound notFound) {
  282.                                                 throw new CoreException("Policy con id ["+idActive.getIdPolicy()+"] non esistente: "+notFound.getMessage(),notFound);
  283.                                             }
  284.                                             if(configurazionePolicy==null){
  285.                                                 throw new CoreException("Policy con id ["+idActive.getIdPolicy()+"] non esistente?");
  286.                                             }
  287.                                         
  288.                                             if(configurazionePolicy.getValore2()!=null) {
  289.                                                 sogliaRichiesta = configurazionePolicy.getValore2();
  290.                                             }
  291.                                             if(configurazionePolicy.getValore()!=null) {
  292.                                                 sogliaRisposta = configurazionePolicy.getValore();
  293.                                             }
  294.                                         }
  295.                                         
  296.                                         if(sogliaRichiesta>0) {
  297.                                             boolean updateRichiesta = false;
  298.                                             if(soglie.getRichiesta()==null 
  299.                                                     ||
  300.                                                     (sogliaRichiesta<soglie.getRichiesta().getSogliaKb())
  301.                                                     ) {
  302.                                                 updateRichiesta = true;
  303.                                             }
  304.                                             if(updateRichiesta) {
  305.                                                 soglie.setRichiesta(build(sogliaRichiesta, attivazionePolicy, protocolFactory, configPdDManager, requestInfo, tipoPdD, nomePorta));
  306.                                             }
  307.                                         }
  308.                                         
  309.                                         if(sogliaRisposta>0) {
  310.                                             boolean updateRisposta = false;
  311.                                             if(soglie.getRisposta()==null
  312.                                                     ||
  313.                                                     (sogliaRisposta<soglie.getRisposta().getSogliaKb())
  314.                                                     ) {
  315.                                                 updateRisposta = true;
  316.                                             }
  317.                                             if(updateRisposta) {
  318.                                                 soglie.setRisposta(build(sogliaRisposta, attivazionePolicy, protocolFactory, configPdDManager, requestInfo, tipoPdD, nomePorta));
  319.                                             }
  320.                                         }
  321.                                         
  322.                                         policyRispettate++;
  323.                                             
  324.                                         if(!attivazionePolicy.isContinuaValutazione()) {
  325.                                             policyRispettataCheRichiedeBreak = true;
  326.                                         }

  328.                                     }
  329.                                     
  330.                                 }
  331.                                 else{
  332.                                     
  333.                                     policyFiltrate++;
  334.                                     
  335.                                     // Emetto Diagnostico Policy Filtrata
  336.                                     if(policyRispettataCheRichiedeBreak) {
  337.                                         logDebug(log,"[policy: "+alias+"] "+GeneratoreMessaggiErrore.TEMPLATE_POLICY_FILTRATA_MOTIVO_BREAK);
  338.                                     }
  339.                                     else if(policyViolataBreak) {
  340.                                         logDebug(log,"[policy: "+alias+"] "+GeneratoreMessaggiErrore.TEMPLATE_POLICY_FILTRATA_MOTIVO_BREAK_VIOLATA);
  341.                                     }
  342.                                     else {
  343.                                         logDebug(log,"[policy: "+alias+"] "+GeneratoreMessaggiErrore.TEMPLATE_POLICY_FILTRATA_MOTIVO_FILTRO+ PolicyUtilities.toStringFilter(attivazionePolicy.getFiltro()));
  344.                                     }
  345.                                     
  346.                                 }
  347.                                 
  348.                             }
  349.                             else{
  350.                                 
  351.                                 policyDisabilitate++;
  352.                                 
  353.                                 // Emetto Diagnostico Policy Disabilitata
  354.                                 logDebug(log,"[policy: "+idActive.getNome()+"] policy disabilitata");
  355.                                 
  356.                             }
  357.                             
  358.                         }
  359.                         catch(Throwable e){
  360.                             
  361.                             policyInErrore++;

  363.                             // Emetto Diagnostico Policy in Errore
  364.                             log.error("Errore durante il controllo della policy con id["+idActive.getNome()+"]: "+e.getMessage(),e);
  365.                             
  366.                         }
  367.                     }
  368.                 
  369.                 }
  370.             
  371.                 logDebug(log,"Valutazione policy totali["+policyTotali+"] disabilitate["+policyDisabilitate+"] filtrate["+policyFiltrate+"] utilizzate["+policyRispettate+"] inErrore["+policyInErrore+"]");
  372.                                 
  373.             }
  374.         }catch(Exception e){
  375.             throw new CoreException("Errore durante l'identificazione dei limiti sulla dimensione dei messaggi: "+e.getMessage(), e);
  376.         }
  377.         
  378.         if(soglie!=null &&
  379.             (soglie.getRichiesta()==null || soglie.getRisposta()==null) 
  380.             ){
  381.             soglie = null;
  382.         }
  383.         
  384.         return soglie;
  385.     }
  386.     
  387.     private static SogliaDimensioneMessaggio build(long sogliaKb, AttivazionePolicy attivazionePolicy, IProtocolFactory<?> protocolFactory, ConfigurazionePdDManager configPdDManager, RequestInfo requestInfo,
  388.             TipoPdD tipoPdD, String nomePorta) throws ProtocolException, DriverConfigurazioneException {
  389.         SogliaDimensioneMessaggio soglia = new SogliaDimensioneMessaggio();
  390.         soglia.setSogliaKb(sogliaKb);
  391.         
  392.         OpenSPCoop2Properties op2Properties = OpenSPCoop2Properties.getInstance();
  393.         soglia.setUseContentLengthHeader(op2Properties.isLimitedInputStreamUseContentLength());
  394.         soglia.setUseContentLengthHeaderAcceptZeroValue(op2Properties.isLimitedInputStreamUseContentLengthAcceptZeroValue());
  395.         
  396.         boolean policyPorta = attivazionePolicy.getFiltro()!=null && attivazionePolicy.getFiltro().getEnabled() &&
  397.                 attivazionePolicy.getFiltro().getNomePorta()!=null &&
  398.                 attivazionePolicy.getFiltro().getRuoloPorta()!=null;
  399.         soglia.setPolicyGlobale(!policyPorta);

  401.         soglia.setNomePolicy(PolicyUtilities.getNomeActivePolicy(attivazionePolicy.getAlias(), attivazionePolicy.getIdActivePolicy()));
  402.         
  403.         String idPolicyConGruppo = null;
  404.         String configurazione = null;
  405.         String idAPI = null;
  406.         if(!soglia.isPolicyGlobale()) {
  407.             idAPI = PolicyVerifier.getIdAPI(attivazionePolicy, protocolFactory, configPdDManager, requestInfo);
  408.         }
  409.         idPolicyConGruppo = PolicyUtilities.buildIdConfigurazioneEventoPerPolicy(attivazionePolicy, null, idAPI);
  410.         configurazione = PolicyUtilities.buildConfigurazioneEventoPerPolicy(attivazionePolicy, soglia.isPolicyGlobale());
  411.         soglia.setIdPolicyConGruppo(idPolicyConGruppo);
  412.         soglia.setConfigurazione(configurazione);
  413.         
  414.         IDPortaDelegata idPD = null;
  415.         IDPortaApplicativa idPA = null;
  416.         if(tipoPdD!=null && nomePorta!=null && StringUtils.isNotEmpty(nomePorta)) {
  417.             if(TipoPdD.DELEGATA.equals(tipoPdD)) {
  418.                 idPD = new IDPortaDelegata();
  419.                 idPD.setNome(nomePorta);
  420.             }
  421.             else {
  422.                 idPA = new IDPortaApplicativa();
  423.                 idPA.setNome(nomePorta);
  424.             }
  425.         }
  426.         else if(policyPorta) {
  427.             if(org.openspcoop2.core.controllo_traffico.constants.RuoloPolicy.DELEGATA.equals(attivazionePolicy.getFiltro().getRuoloPorta())) {
  428.                 idPD = new IDPortaDelegata();
  429.                 idPD.setNome(attivazionePolicy.getFiltro().getNomePorta());
  430.             }
  431.             else {
  432.                 idPA = new IDPortaApplicativa();
  433.                 idPA.setNome(attivazionePolicy.getFiltro().getNomePorta());
  434.             }
  435.         }
  436.         
  437.         List<Proprieta> listP = null;
  438.         if(idPD!=null) {
  439.             listP = readProperties(idPD, configPdDManager, requestInfo);
  440.         }
  441.         else {
  442.             listP = readProperties(idPA, configPdDManager, requestInfo);
  443.         }
  444.         
  445.         if(listP!=null && !listP.isEmpty()) {
  446.             soglia.setUseContentLengthHeader(CostantiProprieta.isRateLimitingUseHttpContentLength(listP, soglia.isUseContentLengthHeader()));
  447.             soglia.setUseContentLengthHeaderAcceptZeroValue(CostantiProprieta.isRateLimitingUseHttpContentLengthAcceptZeroValue(listP, soglia.isUseContentLengthHeaderAcceptZeroValue()));
  448.         }
  449.         
  450.         return soglia;
  451.     }
  452.     private static List<Proprieta> readProperties(IDPortaDelegata idPD, ConfigurazionePdDManager configPdDManager, RequestInfo requestInfo) throws DriverConfigurazioneException {
  453.         List<Proprieta> listP = null;
  454.         PortaDelegata pd = configPdDManager.getPortaDelegataSafeMethod(idPD, requestInfo);
  455.         if(pd!=null) {
  456.             listP = pd.getProprieta();
  457.         }
  458.         return listP;
  459.     }
  460.     private static List<Proprieta> readProperties(IDPortaApplicativa idPA, ConfigurazionePdDManager configPdDManager, RequestInfo requestInfo) throws DriverConfigurazioneException {
  461.         List<Proprieta> listP = null;
  462.         PortaApplicativa pa = configPdDManager.getPortaApplicativaSafeMethod(idPA, requestInfo);
  463.         if(pa!=null) {
  464.             listP = pa.getProprieta();
  465.         }
  466.         return listP;
  467.     }
  468.     
  469. }
Created with JaCoCo 0.8.8.202204050719