ConfigurazionePdD_controlloTraffico.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.config;

  23. import java.sql.Connection;
  24. import java.util.ArrayList;
  25. import java.util.HashMap;
  26. import java.util.List;
  27. import java.util.Map;

  29. import org.openspcoop2.core.commons.dao.DAOFactory;
  30. import org.openspcoop2.core.config.Proprieta;
  31. import org.openspcoop2.core.config.driver.DriverConfigurazioneException;
  32. import org.openspcoop2.core.config.driver.DriverConfigurazioneNotFound;
  33. import org.openspcoop2.core.config.driver.db.DriverConfigurazioneDB;
  34. import org.openspcoop2.core.constants.TipoPdD;
  35. import org.openspcoop2.core.controllo_traffico.AttivazionePolicy;
  36. import org.openspcoop2.core.controllo_traffico.ConfigurazioneGenerale;
  37. import org.openspcoop2.core.controllo_traffico.ConfigurazionePolicy;
  38. import org.openspcoop2.core.controllo_traffico.ConfigurazioneRateLimitingProprieta;
  39. import org.openspcoop2.core.controllo_traffico.ElencoIdPolicy;
  40. import org.openspcoop2.core.controllo_traffico.ElencoIdPolicyAttive;
  41. import org.openspcoop2.core.controllo_traffico.IdActivePolicy;
  42. import org.openspcoop2.core.controllo_traffico.IdPolicy;
  43. import org.openspcoop2.core.controllo_traffico.beans.UniqueIdentifierUtilities;
  44. import org.openspcoop2.core.controllo_traffico.constants.RuoloPolicy;
  45. import org.openspcoop2.core.controllo_traffico.constants.TipoRisorsaPolicyAttiva;
  46. import org.openspcoop2.core.controllo_traffico.dao.IAttivazionePolicyServiceSearch;
  47. import org.openspcoop2.core.controllo_traffico.dao.IConfigurazionePolicyServiceSearch;
  48. import org.openspcoop2.generic_project.exception.NotFoundException;
  49. import org.openspcoop2.generic_project.expression.IPaginatedExpression;
  50. import org.openspcoop2.generic_project.expression.SortOrder;
  51. import org.openspcoop2.generic_project.utils.ServiceManagerProperties;
  52. import org.openspcoop2.pdd.core.controllo_traffico.policy.config.PolicyConfiguration;
  53. import org.openspcoop2.pdd.logger.OpenSPCoop2Logger;

  55. /**     
  56.  * ConfigurazionePdD_controlloTraffico
  57.  *
  58.  * @author Poli Andrea (poli@link.it)
  59.  * @author $Author$
  60.  * @version $Rev$, $Date$
  61.  */
  62. public class ConfigurazionePdD_controlloTraffico extends AbstractConfigurazionePdDConnectionResourceManager {

  64.     private ServiceManagerProperties smp;
  65.     
  66.     
  67.     public ConfigurazionePdD_controlloTraffico(OpenSPCoop2Properties openspcoopProperties, DriverConfigurazioneDB driver, boolean useConnectionPdD) {
  68.         super(openspcoopProperties, driver, useConnectionPdD, OpenSPCoop2Logger.getLoggerOpenSPCoopControlloTrafficoSql(openspcoopProperties.isControlloTrafficoDebug()));
  69.             
  70.         this.smp = new ServiceManagerProperties();
  71.         this.smp.setShowSql(this.openspcoopProperties.isControlloTrafficoDebug());
  72.         this.smp.setDatabaseType(this.driver.getTipoDB());
  73.     }
  74.     
  75.     
  76.     
  77.     
  78.     private static ConfigurazioneGenerale configurazioneGenerale = null;
  79.     public ConfigurazioneGenerale getConfigurazioneControlloTraffico(Connection connectionPdD) throws DriverConfigurazioneException, DriverConfigurazioneNotFound{
  80.         
  81.         if( this.configurazioneDinamica || ConfigurazionePdD_controlloTraffico.configurazioneGenerale==null){
  82.             ConfigurazionePdDConnectionResource cr = null;
  83.             try{
  84.                 cr = this.getConnection(connectionPdD, "ControlloTraffico.getConfigurazioneGenerale");
  85.                 org.openspcoop2.core.controllo_traffico.dao.IServiceManager sm = 
  86.                         (org.openspcoop2.core.controllo_traffico.dao.IServiceManager) DAOFactory.getInstance(this.log).
  87.                         getServiceManager(org.openspcoop2.core.controllo_traffico.utils.ProjectInfo.getInstance(),
  88.                                 cr.connectionDB,this.smp,this.log);
  89.                 
  90.                 ConfigurazionePdD_controlloTraffico.configurazioneGenerale = sm.getConfigurazioneGeneraleServiceSearch().get();
  91.             }
  92.             catch(NotFoundException e) {
  93.                 String errorMsg = "Configurazione del Controllo del Traffico non trovata: "+e.getMessage();
  94.                 this.log.debug(errorMsg,e);
  95.                 throw new DriverConfigurazioneNotFound(errorMsg,e);
  96.             }
  97.             catch(Exception e){
  98.                 String errorMsg = "Errore durante la configurazione del Controllo del Traffico: "+e.getMessage();
  99.                 this.log.error(errorMsg,e);
  100.                 throw new DriverConfigurazioneException(errorMsg,e);
  101.             }
  102.             finally {
  103.                 this.releaseConnection(cr);
  104.             }
  105.         }

  107.         return ConfigurazionePdD_controlloTraffico.configurazioneGenerale;

  109.     }
  110.     
  111.     
  112.     
  113.     
  114.     private static PolicyConfiguration configurazionePolicyRateLimitingGlobali = null;
  115.     public PolicyConfiguration getConfigurazionePolicyRateLimitingGlobali(Connection connectionPdD) throws DriverConfigurazioneException, DriverConfigurazioneNotFound{
  116.         
  117.         if( this.configurazioneDinamica || ConfigurazionePdD_controlloTraffico.configurazionePolicyRateLimitingGlobali==null){
  118.             ConfigurazionePdDConnectionResource cr = null;
  119.             try{
  120.                 cr = this.getConnection(connectionPdD, "ControlloTraffico.getConfigurazionePolicyRateLimitingGlobali");
  121.                                 
  122.                 org.openspcoop2.core.controllo_traffico.dao.IServiceManager sm = 
  123.                         (org.openspcoop2.core.controllo_traffico.dao.IServiceManager) DAOFactory.getInstance(this.log).
  124.                         getServiceManager(org.openspcoop2.core.controllo_traffico.utils.ProjectInfo.getInstance(),
  125.                                 cr.connectionDB,this.smp,this.log);
  126.                 
  127.                 List<Proprieta> list = new ArrayList<Proprieta>();
  128.                 List<ConfigurazioneRateLimitingProprieta> l = sm.getConfigurazioneRateLimitingProprietaServiceSearch().findAll(sm.getConfigurazioneRateLimitingProprietaServiceSearch().newPaginatedExpression());
  129.                 if(l!=null && !l.isEmpty()) {
  130.                     for (ConfigurazioneRateLimitingProprieta configurazioneRateLimitingProprieta : l) {
  131.                         Proprieta p = new Proprieta();
  132.                         p.setNome(configurazioneRateLimitingProprieta.getNome());
  133.                         p.setValore(configurazioneRateLimitingProprieta.getValore());
  134.                         list.add(p);
  135.                     }
  136.                 }
  137.                 
  138.                 ConfigurazionePdD_controlloTraffico.configurazionePolicyRateLimitingGlobali = new PolicyConfiguration(list);
  139.             }
  140.             catch(NotFoundException e) {
  141.                 String errorMsg = "Configurazione delle policy globali di rate limiting non trovata: "+e.getMessage();
  142.                 this.log.debug(errorMsg,e);
  143.                 throw new DriverConfigurazioneNotFound(errorMsg,e);
  144.             }
  145.             catch(Exception e){
  146.                 String errorMsg = "Errore durante la configurazione del Controllo del Traffico: "+e.getMessage();
  147.                 this.log.error(errorMsg,e);
  148.                 throw new DriverConfigurazioneException(errorMsg,e);
  149.             }
  150.             finally {
  151.                 this.releaseConnection(cr);
  152.             }
  153.         }

  155.         return ConfigurazionePdD_controlloTraffico.configurazionePolicyRateLimitingGlobali;

  157.     }
  158.     
  159.     
  160.     
  161.     public Map<TipoRisorsaPolicyAttiva, ElencoIdPolicyAttive> getElencoIdPolicyAttiveAPI(Connection connectionPdD, TipoPdD tipoPdD, String nomePorta) throws DriverConfigurazioneException, DriverConfigurazioneNotFound{
  162.         return this.getElencoIdPolicyApiAttiveEngine(connectionPdD, tipoPdD, nomePorta, true,
  163.                 false,true);
  164.     }
  165.     public Map<TipoRisorsaPolicyAttiva, ElencoIdPolicyAttive> getElencoIdPolicyAttiveGlobali(Connection connectionPdD) throws DriverConfigurazioneException, DriverConfigurazioneNotFound{
  166.         return this.getElencoIdPolicyApiAttiveEngine(connectionPdD, null, null, false,
  167.                 false,true);
  168.     }
  169.     public Map<TipoRisorsaPolicyAttiva, ElencoIdPolicyAttive> getElencoIdPolicyAttiveAPIDimensioneMessaggio(Connection connectionPdD, TipoPdD tipoPdD, String nomePorta) throws DriverConfigurazioneException, DriverConfigurazioneNotFound{
  170.         return this.getElencoIdPolicyApiAttiveEngine(connectionPdD, tipoPdD, nomePorta, true,
  171.                 true,false);
  172.     }
  173.     public Map<TipoRisorsaPolicyAttiva, ElencoIdPolicyAttive> getElencoIdPolicyAttiveGlobaliDimensioneMessaggio(Connection connectionPdD) throws DriverConfigurazioneException, DriverConfigurazioneNotFound{
  174.         return this.getElencoIdPolicyApiAttiveEngine(connectionPdD, null, null, false,
  175.                 true,false);
  176.     }
  177.     private Map<TipoRisorsaPolicyAttiva, ElencoIdPolicyAttive> getElencoIdPolicyApiAttiveEngine(Connection connectionPdD, TipoPdD tipoPdD, String nomePorta, boolean api, 
  178.             boolean includiSoloPolicyDimensioneMessaggio, boolean escludiPolicyDimensioneMessaggio) throws DriverConfigurazioneException, DriverConfigurazioneNotFound{
  179.         
  180.         String prefix = "";
  181.         if(includiSoloPolicyDimensioneMessaggio) {
  182.             prefix = " [DimensioneMessaggio]";
  183.         }
  184.         
  185.         if(api) {
  186.             if(tipoPdD==null) {
  187.                 throw new DriverConfigurazioneException("Tipo PdD non fornito; richiesto per una policy API"+prefix);
  188.             }
  189.             if(nomePorta==null) {
  190.                 throw new DriverConfigurazioneException("Nome Porta non fornito; richiesto per una policy API"+prefix);
  191.             }
  192.         }
  193.         
  194.         ConfigurazionePdDConnectionResource cr = null;
  195.         try{
  196.             cr = this.getConnection(connectionPdD, "ControlloTraffico.getElencoIdPolicyAttive");
  197.             org.openspcoop2.core.controllo_traffico.dao.IServiceManager sm = 
  198.                     (org.openspcoop2.core.controllo_traffico.dao.IServiceManager) DAOFactory.getInstance(this.log).
  199.                     getServiceManager(org.openspcoop2.core.controllo_traffico.utils.ProjectInfo.getInstance(),
  200.                             cr.connectionDB,this.smp,this.log);
  201.             
  202.             IAttivazionePolicyServiceSearch search =  sm.getAttivazionePolicyServiceSearch();
  203.             IPaginatedExpression expression = search.newPaginatedExpression();
  204.             
  205.             if(api) {
  206.                 if(TipoPdD.DELEGATA.equals(tipoPdD)) {
  207.                     expression.equals(AttivazionePolicy.model().FILTRO.RUOLO_PORTA, RuoloPolicy.DELEGATA.getValue());
  208.                 }
  209.                 else {
  210.                     expression.equals(AttivazionePolicy.model().FILTRO.RUOLO_PORTA, RuoloPolicy.APPLICATIVA.getValue());
  211.                 }
  212.                 expression.equals(AttivazionePolicy.model().FILTRO.NOME_PORTA,nomePorta);
  213.             }
  214.             else {
  215.                 expression.isNull(AttivazionePolicy.model().FILTRO.NOME_PORTA);
  216.             }
  217.             
  218.             expression.limit(100000); // non dovrebbero esistere tante regole
  219.             expression.addOrder(AttivazionePolicy.model().POSIZIONE, SortOrder.ASC);
  220.             List<IdActivePolicy> list = search.findAllIds(expression);
  221.             if(list!=null && list.size()>0){
  222.                 
  223.                 // Devo raggrupparle per risorse.
  224.                 // Ordinate lo sono gia' poiche' ho fatto l'ordine precedentemente
  225.                 Map<TipoRisorsaPolicyAttiva, ElencoIdPolicyAttive> map = new HashMap<>();
  226.                 for (IdActivePolicy idActivePolicy : list) {
  227.                     
  228.                     ConfigurazionePolicy confPolicy = null;
  229.                     try {
  230.                         confPolicy = this.getConfigurazionePolicy(cr, idActivePolicy.getIdPolicy());
  231.                     }
  232.                     catch(DriverConfigurazioneNotFound e) {
  233.                         this.log.error("Configurazione Policy '"+idActivePolicy.getIdPolicy()+"' non esistente ? ",e);
  234.                         throw new NotFoundException("Configurazione Policy '"+idActivePolicy.getIdPolicy()+"' non esistente", e);   
  235.                     }
  236.                     if(confPolicy==null) {
  237.                         throw new NotFoundException("Configurazione Policy '"+idActivePolicy.getIdPolicy()+"' non esistente");  
  238.                     }
  239.                     
  240.                     ElencoIdPolicyAttive elencoIdPolicy = null;
  241.                     
  242.                     TipoRisorsaPolicyAttiva tipoPolicyAttiva = TipoRisorsaPolicyAttiva.getTipo(confPolicy.getRisorsa(), confPolicy.isSimultanee());
  243.                     
  244.                     if(escludiPolicyDimensioneMessaggio) {
  245.                         if(TipoRisorsaPolicyAttiva.DIMENSIONE_MASSIMA_MESSAGGIO.equals(tipoPolicyAttiva)) {
  246.                             continue;
  247.                         }
  248.                     }
  249.                     else if(includiSoloPolicyDimensioneMessaggio) {
  250.                         if(!TipoRisorsaPolicyAttiva.DIMENSIONE_MASSIMA_MESSAGGIO.equals(tipoPolicyAttiva)) {
  251.                             continue;
  252.                         }
  253.                     }
  254.                     
  255.                     if(map.containsKey(tipoPolicyAttiva)) {
  256.                         elencoIdPolicy = map.get(tipoPolicyAttiva);
  257.                     }
  258.                     else {
  259.                         elencoIdPolicy = new ElencoIdPolicyAttive();
  260.                         map.put(tipoPolicyAttiva, elencoIdPolicy);
  261.                     }
  262.                     
  263.                     elencoIdPolicy.addIdActivePolicy(idActivePolicy);
  264.                 }
  265.                 
  266.                 if(map.isEmpty()) {
  267.                     if(api) {
  268.                         throw new NotFoundException("policy API non esistenti per la porta '"+nomePorta+"' (ruolo: "+tipoPdD.getTipo()+")"+prefix);
  269.                     }
  270.                     else {
  271.                         throw new NotFoundException("policy globali non esistenti"+prefix); 
  272.                     }
  273.                 }
  274.                 
  275.                 return map;
  276.             }
  277.             else {
  278.                 if(api) {
  279.                     throw new NotFoundException("policy API non esistenti per la porta '"+nomePorta+"' (ruolo: "+tipoPdD.getTipo()+")"+prefix);
  280.                 }
  281.                 else {
  282.                     throw new NotFoundException("policy globali non esistenti"+prefix); 
  283.                 }
  284.             }
  285.         }
  286.         catch(NotFoundException e) {
  287.             String errorMsg = "ElencoIdPolicyAttive del Controllo del Traffico non trovata: "+e.getMessage();
  288.             this.log.debug(errorMsg,e);
  289.             throw new DriverConfigurazioneNotFound(errorMsg,e);
  290.         }
  291.         catch(Exception e){
  292.             String errorMsg = "Errore durante la lettura dell'ElencoIdPolicyAttive del Controllo del Traffico: "+e.getMessage();
  293.             this.log.error(errorMsg,e);
  294.             throw new DriverConfigurazioneException(errorMsg,e);
  295.         }
  296.         finally {
  297.             this.releaseConnection(cr);
  298.         }

  300.     }
  301.     
  302.     
  303.     
  304.     
  305.     
  306.     public AttivazionePolicy getAttivazionePolicy(Connection connectionPdD, String id) throws DriverConfigurazioneException, DriverConfigurazioneNotFound{
  307.         
  308.         ConfigurazionePdDConnectionResource cr = null;
  309.         try{
  310.             cr = this.getConnection(connectionPdD, "ControlloTraffico.getAttivazionePolicy_"+id);
  311.             org.openspcoop2.core.controllo_traffico.dao.IServiceManager sm = 
  312.                     (org.openspcoop2.core.controllo_traffico.dao.IServiceManager) DAOFactory.getInstance(this.log).
  313.                     getServiceManager(org.openspcoop2.core.controllo_traffico.utils.ProjectInfo.getInstance(),
  314.                             cr.connectionDB,this.smp,this.log);
  315.             
  316.             IAttivazionePolicyServiceSearch search =  sm.getAttivazionePolicyServiceSearch();
  317.             IdActivePolicy policyId = new IdActivePolicy();
  318.             policyId.setNome(UniqueIdentifierUtilities.extractIdActivePolicy(id));
  319.             return search.get(policyId);
  320.         }
  321.         catch(NotFoundException e) {
  322.             String errorMsg = "AttivazionePolicy del Controllo del Traffico non trovata: "+e.getMessage();
  323.             this.log.debug(errorMsg,e);
  324.             throw new DriverConfigurazioneNotFound(errorMsg,e);
  325.         }
  326.         catch(Exception e){
  327.             String errorMsg = "Errore durante la lettura dell'AttivazionePolicy del Controllo del Traffico: "+e.getMessage();
  328.             this.log.error(errorMsg,e);
  329.             throw new DriverConfigurazioneException(errorMsg,e);
  330.         }
  331.         finally {
  332.             this.releaseConnection(cr);
  333.         }

  335.     }
  336.     
  337.     
  338.     
  339.     
  340.     public ElencoIdPolicy getElencoIdPolicy(Connection connectionPdD) throws DriverConfigurazioneException, DriverConfigurazioneNotFound{
  341.         
  342.         ConfigurazionePdDConnectionResource cr = null;
  343.         try{
  344.             cr = this.getConnection(connectionPdD, "ControlloTraffico.getElencoIdPolicy");
  345.             org.openspcoop2.core.controllo_traffico.dao.IServiceManager sm = 
  346.                     (org.openspcoop2.core.controllo_traffico.dao.IServiceManager) DAOFactory.getInstance(this.log).
  347.                     getServiceManager(org.openspcoop2.core.controllo_traffico.utils.ProjectInfo.getInstance(),
  348.                             cr.connectionDB,this.smp,this.log);
  349.             
  350.             ElencoIdPolicy elencoIdPolicy = new ElencoIdPolicy();
  351.             IConfigurazionePolicyServiceSearch search =  sm.getConfigurazionePolicyServiceSearch();
  352.             IPaginatedExpression expression = search.newPaginatedExpression();
  353.             expression.limit(100000); // non dovrebbero esistere tante regole
  354.             List<IdPolicy> list = search.findAllIds(expression);
  355.             if(list!=null && !list.isEmpty()){
  356.                 elencoIdPolicy.setIdPolicyList(list);
  357.             }
  358.             return elencoIdPolicy;
  359.         }
  360.         catch(Exception e){
  361.             String errorMsg = "Errore durante la lettura dell'ElencoIdPolicy del Controllo del Traffico: "+e.getMessage();
  362.             this.log.error(errorMsg,e);
  363.             throw new DriverConfigurazioneException(errorMsg,e);
  364.         }
  365.         finally {
  366.             this.releaseConnection(cr);
  367.         }

  369.     }
  370.     
  371.     
  372.     
  373.     
  374.     
  375.     public ConfigurazionePolicy getConfigurazionePolicy(Connection connectionPdD, String id) throws DriverConfigurazioneException, DriverConfigurazioneNotFound{
  376.         
  377.         ConfigurazionePdDConnectionResource cr = null;
  378.         try{
  379.             cr = this.getConnection(connectionPdD, "ControlloTraffico.getConfigurazionePolicy_"+id);
  380.             return getConfigurazionePolicy(cr, id);
  381.         }
  382.         catch(DriverConfigurazioneNotFound e){
  383.             throw e;
  384.         }
  385.         catch(DriverConfigurazioneException e){
  386.             throw e;
  387.         }
  388.         catch(Exception e){
  389.             String errorMsg = "Errore durante la lettura della ConfigurazionePolicy del Controllo del Traffico: "+e.getMessage();
  390.             this.log.error(errorMsg,e);
  391.             throw new DriverConfigurazioneException(errorMsg,e);
  392.         }
  393.         finally {
  394.             this.releaseConnection(cr);
  395.         }

  397.     }
  398.     private ConfigurazionePolicy getConfigurazionePolicy(ConfigurazionePdDConnectionResource crParam, String id) throws DriverConfigurazioneException, DriverConfigurazioneNotFound{
  399.         
  400.         try{
  401.             org.openspcoop2.core.controllo_traffico.dao.IServiceManager sm = 
  402.                     (org.openspcoop2.core.controllo_traffico.dao.IServiceManager) DAOFactory.getInstance(this.log).
  403.                     getServiceManager(org.openspcoop2.core.controllo_traffico.utils.ProjectInfo.getInstance(),
  404.                             crParam.connectionDB,this.smp,this.log);
  405.             
  406.             IConfigurazionePolicyServiceSearch search =  sm.getConfigurazionePolicyServiceSearch();
  407.             IdPolicy policyId = new IdPolicy();
  408.             policyId.setNome(id);
  409.             return search.get(policyId);

  411.         }
  412.         catch(NotFoundException e) {
  413.             String errorMsg = "ConfigurazionePolicy del Controllo del Traffico non trovata: "+e.getMessage();
  414.             this.log.debug(errorMsg,e);
  415.             throw new DriverConfigurazioneNotFound(errorMsg,e);
  416.         }
  417.         catch(Exception e){
  418.             String errorMsg = "Errore durante la lettura della ConfigurazionePolicy del Controllo del Traffico: "+e.getMessage();
  419.             this.log.error(errorMsg,e);
  420.             throw new DriverConfigurazioneException(errorMsg,e);
  421.         }

  423.     }
  424.     
  425.     
  426. }
Created with JaCoCo 0.8.8.202204050719