ConfigurazioneUtilities.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.web.ctrlstat.servlet.config;

  23. import java.util.ArrayList;
  24. import java.util.List;

  26. import org.apache.commons.lang.StringUtils;
  27. import org.openspcoop2.core.allarmi.Allarme;
  28. import org.openspcoop2.core.allarmi.AllarmeHistory;
  29. import org.openspcoop2.core.allarmi.IdAllarme;
  30. import org.openspcoop2.core.allarmi.constants.RuoloPorta;
  31. import org.openspcoop2.core.config.Configurazione;
  32. import org.openspcoop2.core.config.PortaApplicativa;
  33. import org.openspcoop2.core.config.PortaDelegata;
  34. import org.openspcoop2.core.config.driver.DriverConfigurazioneException;
  35. import org.openspcoop2.core.config.driver.DriverConfigurazioneNotFound;
  36. import org.openspcoop2.core.config.utils.ConfigurazionePdDUtils;
  37. import org.openspcoop2.core.controllo_traffico.AttivazionePolicy;
  38. import org.openspcoop2.core.controllo_traffico.ConfigurazionePolicy;
  39. import org.openspcoop2.core.controllo_traffico.beans.InfoPolicy;
  40. import org.openspcoop2.core.controllo_traffico.constants.RuoloPolicy;
  41. import org.openspcoop2.core.id.IDPortaApplicativa;
  42. import org.openspcoop2.core.id.IDPortaDelegata;
  43. import org.openspcoop2.core.mapping.MappingErogazionePortaApplicativa;
  44. import org.openspcoop2.core.mapping.MappingFruizionePortaDelegata;
  45. import org.openspcoop2.core.registry.driver.DriverRegistroServiziException;
  46. import org.openspcoop2.core.registry.driver.DriverRegistroServiziNotFound;
  47. import org.openspcoop2.message.constants.ServiceBinding;
  48. import org.openspcoop2.web.ctrlstat.core.ControlStationCore;
  49. import org.openspcoop2.web.ctrlstat.core.ControlStationCoreException;
  50. import org.openspcoop2.web.ctrlstat.driver.DriverControlStationException;
  51. import org.openspcoop2.web.ctrlstat.driver.DriverControlStationNotFound;
  52. import org.openspcoop2.web.ctrlstat.servlet.pa.PorteApplicativeCore;
  53. import org.openspcoop2.web.ctrlstat.servlet.pd.PorteDelegateCore;
  54. import org.openspcoop2.web.ctrlstat.servlet.soggetti.SoggettiCore;
  55. import org.openspcoop2.web.lib.mvc.TipoOperazione;

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

  67.     public static boolean alreadyExists(TipoOperazione tipoOperazione, ConfigurazioneCore confCore, ConfigurazioneHelper confHelper, 
  68.             AttivazionePolicy policy, InfoPolicy infoPolicy, RuoloPolicy ruoloPorta, String nomePorta, ServiceBinding serviceBinding,
  69.             StringBuilder existsMessage, String newLine, String modalita) throws Exception {
  70.         if(infoPolicy!=null){
  71.             
  72.             String perApi = "globale";
  73.             if(ruoloPorta!=null && nomePorta!=null && !"".equals(nomePorta)) {
  74.                 perApi = "per l'API";
  75.             }
  76.             
  77.             AttivazionePolicy p = null;
  78.             try {
  79.                 p = confCore.getPolicy(policy.getIdPolicy(),policy.getFiltro(), policy.getGroupBy(),
  80.                         ruoloPorta, nomePorta);
  81.             }catch(DriverControlStationNotFound e) {
  82.                 //ignore
  83.             }
  84.             if(p!=null){
  85.                 if(TipoOperazione.ADD.equals(tipoOperazione) || (p.getId()!=null && policy.getId()!=null && p.getId().longValue()!=policy.getId().longValue())){
  86.                     
  87.                     String prefisso = "Esiste già una attivazione "+perApi+" della policy '"+
  88.                             policy.getIdPolicy()+"' ";
  89.                     if(ConfigurazioneCostanti.PARAMETRO_CONFIGURAZIONE_CONTROLLO_TRAFFICO_POLICY_ACTIVE_POLICY_MODALITA_BUILT_IN.equals(modalita)) {
  90.                         prefisso = "Esiste già una policy "+perApi+" con i criteri indicati ";
  91.                     }
  92.                     
  93.                     String messaggio = prefisso+newLine+
  94.                             "e"+newLine+
  95.                             "Raggruppamento: "+ confHelper.toStringCompactGroupBy(policy.getGroupBy(),ruoloPorta,nomePorta,serviceBinding)+newLine+
  96.                             "e"+newLine+    
  97.                             "Filtro: "+ confHelper.toStringCompactFilter(policy.getFiltro(),ruoloPorta,nomePorta,serviceBinding);
  98.                     existsMessage.append(messaggio);
  99.                     return true; 
  100.                 }
  101.             }
  102.             
  103.             AttivazionePolicy pAlias = null;
  104.             if(policy.getAlias()!=null && !"".equals(policy.getAlias())) {
  105.                 try {
  106.                     pAlias = confCore.getPolicyByAlias(policy.getAlias(),
  107.                             ruoloPorta, nomePorta);
  108.                 }catch(DriverControlStationNotFound e) {
  109.                     //ignore
  110.                 }
  111.                 if(pAlias!=null){
  112.                     if(TipoOperazione.ADD.equals(tipoOperazione) || (pAlias.getId()!=null && policy.getId()!=null && pAlias.getId().longValue()!=policy.getId().longValue())){
  113.                         String messaggio = "Esiste già una policy "+perApi+" con "+ConfigurazioneCostanti.LABEL_PARAMETRO_CONFIGURAZIONE_CONTROLLO_TRAFFICO_POLICY_ACTIVE_POLICY_ALIAS+" '"+policy.getAlias()+"'";
  114.                         existsMessage.append(messaggio);
  115.                         return true; 
  116.                     }
  117.                 }
  118.             }
  119.         }
  120.         
  121.         return false;
  122.     }

  124.     private static String _getAttivazionePolicyTipo(AttivazionePolicy attivazionePolicy) {
  125.         String tipo = "";
  126.         if(attivazionePolicy.getFiltro()!=null && attivazionePolicy.getFiltro().getRuoloPorta()!=null && 
  127.                 StringUtils.isNotEmpty(attivazionePolicy.getFiltro().getNomePorta())) {
  128.             tipo = attivazionePolicy.getFiltro().getRuoloPorta().getValue()+"_"+attivazionePolicy.getFiltro().getNomePorta();
  129.         }
  130.         else {
  131.             tipo = "globale";
  132.         }
  133.         return tipo;
  134.     }
  135.     private static String _buildLabelApi(Allarme allarme, ConfigurazioneHelper confHelper, ConfigurazioneCore confCore) {
  136.         if(allarme.getFiltro()!=null && allarme.getFiltro().isEnabled() && 
  137.                 allarme.getFiltro().getRuoloPorta()!=null && 
  138.                 allarme.getFiltro().getNomePorta()!=null && StringUtils.isNotEmpty(allarme.getFiltro().getNomePorta())) {
  139.             switch (allarme.getFiltro().getRuoloPorta()) {
  140.             case APPLICATIVA:
  141.                 try {
  142.                     PorteApplicativeCore porteApplicativeCore = new PorteApplicativeCore(confCore);
  143.                     IDPortaApplicativa idPA = new IDPortaApplicativa();
  144.                     idPA.setNome(allarme.getFiltro().getNomePorta());
  145.                     PortaApplicativa paFound = porteApplicativeCore.getPortaApplicativa(idPA);
  146.                     MappingErogazionePortaApplicativa mappingPA = porteApplicativeCore.getMappingErogazionePortaApplicativa(paFound);
  147.                     String labelErogazione = confHelper.getLabelIdServizio(mappingPA.getIdServizio());
  148.                     if(!mappingPA.isDefault()) {
  149.                         labelErogazione = labelErogazione+" (gruppo:"+mappingPA.getDescrizione()+")";
  150.                     }
  151.                     return labelErogazione;
  152.                 }catch(Throwable t) {
  153.                     ControlStationCore.getLog().error("Errore durante l'identificazione dell'erogazione: "+t.getMessage(),t);
  154.                 }
  155.                 break;
  156.             case DELEGATA:
  157.                 try {
  158.                     PorteDelegateCore porteDelegateCore = new PorteDelegateCore(confCore);
  159.                     SoggettiCore soggettiCore = new SoggettiCore(confCore);
  160.                     IDPortaDelegata idPD = new IDPortaDelegata();
  161.                     idPD.setNome(allarme.getFiltro().getNomePorta());
  162.                     PortaDelegata pdFound = porteDelegateCore.getPortaDelegata(idPD);
  163.                     MappingFruizionePortaDelegata mappingPD = porteDelegateCore.getMappingFruizionePortaDelegata(pdFound);
  164.                     String labelFruizione = confHelper.getLabelServizioFruizione(soggettiCore.getProtocolloAssociatoTipoSoggetto(mappingPD.getIdFruitore().getTipo()),
  165.                             mappingPD.getIdFruitore(), mappingPD.getIdServizio());
  166.                     if(!mappingPD.isDefault()) {
  167.                         labelFruizione = labelFruizione+" (gruppo:"+mappingPD.getDescrizione()+")";
  168.                     }
  169.                     return labelFruizione;
  170.                 }catch(Throwable t) {
  171.                     ControlStationCore.getLog().error("Errore durante l'identificazione della fruizione: "+t.getMessage(),t);
  172.                 }
  173.                 break;
  174.             default:
  175.                 break;
  176.             }
  177.         }
  178.         return null;
  179.     }
  180.     public static void deleteAttivazionePolicy(List<AttivazionePolicy> policies , ConfigurazioneHelper confHelper, ConfigurazioneCore confCore, String userLogin,
  181.             StringBuilder inUsoMessage, String newLine, List<AttivazionePolicy> policiesRimosse) throws DriverControlStationException, DriverConfigurazioneNotFound, DriverConfigurazioneException, DriverRegistroServiziNotFound, DriverRegistroServiziException, ControlStationCoreException, Exception {
  182.         
  183.         StringBuilder deleteMessage = new StringBuilder();
  184.         
  185.         boolean oneOnlyConfig = false;
  186.         if(policies.size()==1) {
  187.             oneOnlyConfig=true;
  188.         }
  189.         else {
  190.             oneOnlyConfig = true;
  191.             String tipo = _getAttivazionePolicyTipo(policies.get(0));
  192.             for (int i = 1; i < policies.size(); i++) {
  193.                 AttivazionePolicy attivazionePolicyI = policies.get(i);
  194.                 String tipoI = _getAttivazionePolicyTipo(attivazionePolicyI);
  195.                 if(!tipoI.equals(tipo)) {
  196.                     oneOnlyConfig = false;
  197.                     break;
  198.                 }
  199.             }
  200.         }
  201.         
  202.         for (AttivazionePolicy attivazionePolicy : policies) {
  203.             
  204.             boolean delete = true;
  205.             
  206.             boolean policyApi = attivazionePolicy.getFiltro()!=null && attivazionePolicy.getFiltro().isEnabled() &&
  207.                     attivazionePolicy.getFiltro().getRuoloPorta()!=null && 
  208.                     attivazionePolicy.getFiltro().getNomePorta()!=null && StringUtils.isNotEmpty(attivazionePolicy.getFiltro().getNomePorta());
  209.             if("DimensioneMassimaMessaggi".equals(attivazionePolicy.getAlias()) && !policyApi) {
  210.                 if(deleteMessage.length()>0){
  211.                     deleteMessage.append(newLine);
  212.                 }
  213.                 StringBuilder bf = new StringBuilder();
  214.                 bf.append(newLine);
  215.                 bf.append("La policy '"+attivazionePolicy.getAlias()+"' non è eliminabile; è consentito modificarne i valori di soglia o disabilitarla");
  216.                 deleteMessage.append(bf.toString());
  217.                 delete = false;
  218.             }
  219.             
  220.             if(delete && confCore.isConfigurazioneAllarmiEnabled()){
  221.                 
  222.                 RuoloPorta ruoloPorta = null;
  223.                 String nomePorta = null;
  224.                 if(attivazionePolicy.getFiltro()!=null && attivazionePolicy.getFiltro().getRuoloPorta()!=null && 
  225.                         StringUtils.isNotEmpty(attivazionePolicy.getFiltro().getNomePorta())) {
  226.                     switch (attivazionePolicy.getFiltro().getRuoloPorta()) {
  227.                     case DELEGATA:
  228.                         ruoloPorta = RuoloPorta.DELEGATA;
  229.                         break;
  230.                     case APPLICATIVA:
  231.                         ruoloPorta = RuoloPorta.APPLICATIVA;
  232.                         break;
  233.                     default:
  234.                         break;
  235.                     }
  236.                     nomePorta = attivazionePolicy.getFiltro().getNomePorta();
  237.                 }
  238.                 
  239.                 /** throw new NotImplementedException("Da implementare quando verranno aggiunti gli allarmi."); */ 
  240.                 List<Allarme> allarmiObjectUtilizzanoPolicy = confCore.allarmiForPolicyRateLimiting(attivazionePolicy.getIdActivePolicy(),ruoloPorta,nomePorta);
  241.                 List<String> allarmiUtilizzanoPolicy = null;
  242.                 if(allarmiObjectUtilizzanoPolicy!=null && !allarmiObjectUtilizzanoPolicy.isEmpty()) {
  243.                     allarmiUtilizzanoPolicy = new ArrayList<>();
  244.                     for (Allarme allarme : allarmiObjectUtilizzanoPolicy) {
  245.                         String nomeAllarme = allarme.getAlias();
  246.                         if(!oneOnlyConfig) {
  247.                             String labelApi = _buildLabelApi(allarme, confHelper, confCore);
  248.                             if(labelApi!=null) {
  249.                                 nomeAllarme = nomeAllarme + " - "+ labelApi;
  250.                             }
  251.                         }
  252.                         allarmiUtilizzanoPolicy.add(nomeAllarme);               
  253.                     }
  254.                 }
  255.                 
  256.                 if(allarmiUtilizzanoPolicy!=null && !allarmiUtilizzanoPolicy.isEmpty()){
  257.                     StringBuilder bf = new StringBuilder();
  258.                     bf.append(newLine);
  259.                     bf.append("La policy '"+attivazionePolicy.getAlias()+"' risulta utilizzata da ");
  260.                     bf.append(allarmiUtilizzanoPolicy.size());
  261.                     if(allarmiUtilizzanoPolicy.size()<2){
  262.                         bf.append(" allarme");
  263.                     }else{
  264.                         bf.append(" allarmi");
  265.                     }
  266.                     if(oneOnlyConfig) {
  267.                         boolean globale = !(attivazionePolicy.getFiltro()!=null && attivazionePolicy.getFiltro().getRuoloPorta()!=null && 
  268.                                 StringUtils.isNotEmpty(attivazionePolicy.getFiltro().getNomePorta()));
  269.                         if(!globale) {
  270.                             bf.append(RuoloPolicy.APPLICATIVA.equals(attivazionePolicy.getFiltro().getRuoloPorta())?" configurati sull'erogazione":" configurati sulla fruizione");
  271.                         }
  272.                     }
  273.                     bf.append(": ");
  274.                     for (int j = 0; j < allarmiUtilizzanoPolicy.size(); j++) {
  275.                         bf.append(newLine);
  276.                         bf.append("- ").append(allarmiUtilizzanoPolicy.get(j));
  277.                     }
  278.                     
  279.                     if(deleteMessage.length()>0){
  280.                         deleteMessage.append(newLine);
  281.                     }
  282.                     deleteMessage.append(bf.toString());
  283.                     delete = false;
  284.                 }
  285.             }

  287.             if(delete) {
  288.                 // aggiungo elemento alla lista di quelli da cancellare
  289.                 policiesRimosse.add(attivazionePolicy);
  290.             }
  291.             
  292.         }
  293.         
  294.         if(deleteMessage.length()>0){
  295.             if(!policiesRimosse.isEmpty()){
  296.                 inUsoMessage.append("Non è stato possibile completare l'eliminazione di tutti gli elementi selezionati:"+newLine+deleteMessage.toString());
  297.             }
  298.             else{
  299.                 inUsoMessage.append("Non è stato possibile eliminare gli elementi selezionati:"+newLine+deleteMessage.toString());
  300.             }
  301.         }
  302.         
  303.         if(!policiesRimosse .isEmpty()) {
  304. //          eseguo delete
  305.             confCore.performDeleteOperation(userLogin, confHelper.smista(), (Object[]) policiesRimosse.toArray(new AttivazionePolicy[1])); 
  306.         }
  307.             
  308.     }
  309.     
  310.     public static void updatePosizioneAttivazionePolicy(ConfigurazioneCore confCore, InfoPolicy infoPolicy, AttivazionePolicy policy,
  311.             RuoloPolicy ruoloPorta, String nomePorta) throws Exception {
  312.         confCore.updatePosizioneAttivazionePolicy(infoPolicy, policy,
  313.                 ruoloPorta, nomePorta);
  314.     }
  315.     
  316.     public static int getProssimaPosizioneUrlInvocazioneRegola(Configurazione config) {
  317.         return ConfigurazionePdDUtils.getProssimaPosizioneUrlInvocazioneRegola(config);
  318.     }
  319.     
  320.     public static AllarmeHistory createAllarmeHistory(Allarme allarme, String userLogin) {
  321.         // registro la modifica
  322.         AllarmeHistory history = new AllarmeHistory();
  323.         history.setEnabled(allarme.getEnabled());
  324.         history.setAcknowledged(allarme.getAcknowledged());
  325.         history.setDettaglioStato(allarme.getDettaglioStato());
  326.         IdAllarme idConfigurazioneAllarme = new IdAllarme();
  327.         idConfigurazioneAllarme.setNome(allarme.getNome());
  328.         history.setIdAllarme(idConfigurazioneAllarme);
  329.         history.setStato(allarme.getStato());
  330.         history.setTimestampUpdate(allarme.getLasttimestampUpdate());
  331.         history.setUtente(userLogin);
  332.         return history;
  333.     }
  334.     
  335.     public static void deleteAllarmi(List<Allarme> allarmiToRemove , ConfigurazioneHelper confHelper, ConfigurazioneCore confCore, String userLogin,
  336.             StringBuilder inUsoMessage, String newLine, List<Allarme> allarmiRimossi) throws DriverControlStationException, DriverConfigurazioneNotFound, DriverConfigurazioneException, DriverRegistroServiziNotFound, DriverRegistroServiziException, ControlStationCoreException, Exception {
  337.         
  338.         StringBuilder deleteMessage = new StringBuilder();
  339.         
  340.         for (Allarme allarmeDaEliminare : allarmiToRemove) {
  341.             
  342.             boolean delete = true;
  343.             
  344.             List<ConfigurazionePolicy> policyObjectUtilizzanoAllarme = confCore.configurazioneControlloTrafficoConfigurazionePolicyListConApplicabilitaAllarme(allarmeDaEliminare.getNome());
  345.             List<String> policyUtilizzanoAllarme = null;
  346.             if(policyObjectUtilizzanoAllarme!=null && !policyObjectUtilizzanoAllarme.isEmpty()) {
  347.                 policyUtilizzanoAllarme = new ArrayList<>();
  348.                 for (ConfigurazionePolicy policy : policyObjectUtilizzanoAllarme) {
  349.                     String nomePolicy = policy.getIdPolicy();
  350.                     policyUtilizzanoAllarme.add(nomePolicy);                
  351.                 }
  352.             }
  353.             
  354.             if(policyUtilizzanoAllarme!=null && policyUtilizzanoAllarme.size()>0){
  355.                 StringBuilder bf = new StringBuilder();
  356.                 bf.append(newLine);
  357.                 bf.append("L'allarme '"+allarmeDaEliminare.getAlias()+"' risulta utilizzata da ");
  358.                 bf.append(policyUtilizzanoAllarme.size());
  359.                 bf.append(" policy del Controllo del Traffico (criterio di applicabilità)");
  360.                 bf.append(": ");
  361.                 for (int j = 0; j < policyUtilizzanoAllarme.size(); j++) {
  362.                     //if(j>0){
  363.                     bf.append(newLine);
  364.                     //}
  365.                     bf.append("- ").append(policyUtilizzanoAllarme.get(j));
  366.                 }
  367.                 
  368.                 if(deleteMessage.length()>0){
  369.                     deleteMessage.append(newLine);
  370.                 }
  371.                 deleteMessage.append(bf.toString());
  372.                 delete = false;
  373.             }
  374.         
  375.             if(delete) {
  376.                 // aggiungo elemento alla lista di quelli da cancellare
  377.                 allarmiRimossi.add(allarmeDaEliminare);
  378.             }
  379.         }
  380.         
  381.         if(deleteMessage.length()>0){
  382.             if(allarmiRimossi.size()>0){
  383.                 inUsoMessage.append("Non è stato possibile completare l'eliminazione di tutti gli elementi selezionati:"+newLine+deleteMessage.toString());
  384.             }
  385.             else{
  386.                 inUsoMessage.append("Non è stato possibile eliminare gli elementi selezionati:"+newLine+deleteMessage.toString());
  387.             }
  388.         }
  389.         
  390.     }
  391. }
Created with JaCoCo 0.8.8.202204050719