PorteDelegateUtilities.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.pd;

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

  26. import org.apache.commons.lang.StringUtils;
  27. import org.openspcoop2.core.config.Configurazione;
  28. import org.openspcoop2.core.config.PortaDelegata;
  29. import org.openspcoop2.core.config.PortaTracciamento;
  30. import org.openspcoop2.core.config.TracciamentoConfigurazione;
  31. import org.openspcoop2.core.config.TracciamentoConfigurazioneFiletrace;
  32. import org.openspcoop2.core.config.TracciamentoConfigurazioneFiletraceConnector;
  33. import org.openspcoop2.core.config.Transazioni;
  34. import org.openspcoop2.core.config.TrasformazioneRegola;
  35. import org.openspcoop2.core.config.constants.Severita;
  36. import org.openspcoop2.core.config.constants.StatoFunzionalita;
  37. import org.openspcoop2.core.config.driver.DriverConfigurazioneException;
  38. import org.openspcoop2.core.config.driver.DriverConfigurazioneNotFound;
  39. import org.openspcoop2.core.controllo_traffico.constants.RuoloPolicy;
  40. import org.openspcoop2.core.registry.AccordoServizioParteSpecifica;
  41. import org.openspcoop2.core.registry.ConfigurazioneServizioAzione;
  42. import org.openspcoop2.core.registry.Fruitore;
  43. import org.openspcoop2.protocol.utils.EsitiConfigUtils;
  44. import org.openspcoop2.web.ctrlstat.costanti.CostantiControlStation;
  45. import org.openspcoop2.web.ctrlstat.servlet.config.ConfigurazioneCore;
  46. import org.openspcoop2.web.ctrlstat.servlet.config.ConfigurazioneCostanti;

  48. /**
  49.  * PorteDelegateUtilities
  50.  * 
  51.  * @author Andrea Poli (apoli@link.it)
  52.  * @author $Author$
  53.  * @version $Rev$, $Date$
  54.  * 
  55.  */
  56. public class PorteDelegateUtilities {
  57.     
  58.     private PorteDelegateUtilities() {}

  60.     public static void deletePortaDelegataAzioni(PortaDelegata portaDelegata, AccordoServizioParteSpecifica asps,
  61.             PorteDelegateCore porteDelegateCore, PorteDelegateHelper porteDelegateHelper, 
  62.             StringBuilder inUsoMessage, List<String> azioni, 
  63.             String userLogin) throws Exception {
  64.         
  65.         String azioneGiaEsistente = portaDelegata.getAzione().getAzioneDelegata(0); // prendo la prima
  66.         
  67.         ConfigurazioneServizioAzione configAzioni = null; 
  68.         boolean updateASPS = false;
  69.         
  70.         Fruitore fruitore = null;
  71.         for (Fruitore fruitoreCheck : asps.getFruitoreList()) {
  72.             if(fruitoreCheck.getTipo().equals(portaDelegata.getTipoSoggettoProprietario()) && fruitoreCheck.getNome().equals(portaDelegata.getNomeSoggettoProprietario())) {
  73.                 fruitore = fruitoreCheck;
  74.                 break;
  75.             }
  76.         }
  77.         if(fruitore==null) {
  78.             throw new Exception("Fruitore con id '"+portaDelegata.getTipoSoggettoProprietario()+"/"+portaDelegata.getNomeSoggettoProprietario()+"' non trovata");
  79.         }
  80.         for (int j = 0; j < fruitore.sizeConfigurazioneAzioneList(); j++) {
  81.             ConfigurazioneServizioAzione config = fruitore.getConfigurazioneAzione(j);
  82.             if(config!=null) {
  83.                 if(config.getAzioneList().contains(azioneGiaEsistente)) {
  84.                     configAzioni = config;
  85.                     break;
  86.                 }
  87.             }
  88.         }
  89.         
  90.         ConfigurazioneCore confCore = new ConfigurazioneCore(porteDelegateCore);
  91.         StringBuilder bfTrasformazioni = new StringBuilder();
  92.         StringBuilder bfCT = new StringBuilder();
  93.         
  94.         for (int i = 0; i < azioni.size(); i++) {

  96.             String azione = azioni.get(i);
  97.             
  98.             boolean usedInTrasformazioni = false;
  99.             if(portaDelegata.getTrasformazioni()!=null && portaDelegata.getTrasformazioni().sizeRegolaList()>0) {
  100.                 for (TrasformazioneRegola trasformazioneRegola : portaDelegata.getTrasformazioni().getRegolaList()) {
  101.                     if(trasformazioneRegola.getApplicabilita()!=null && trasformazioneRegola.getApplicabilita().getAzioneList()!=null &&
  102.                             trasformazioneRegola.getApplicabilita().getAzioneList().contains(azione)) {
  103.                         usedInTrasformazioni = true;
  104.                         break;
  105.                     }
  106.                 }
  107.             }
  108.             
  109.             if(confCore.usedInConfigurazioneControlloTrafficoAttivazionePolicy(RuoloPolicy.DELEGATA, portaDelegata.getNome(), azione)) {
  110.                 if(bfCT.length()>0) {
  111.                     bfCT.append(",");
  112.                 }
  113.                 bfCT.append(azione);
  114.             }   
  115.             else if(usedInTrasformazioni) {
  116.                 if(bfTrasformazioni.length()>0) {
  117.                     bfTrasformazioni.append(",");
  118.                 }
  119.                 bfTrasformazioni.append(azione);
  120.             }
  121.             else {
  122.                 for (int j = 0; j < portaDelegata.getAzione().sizeAzioneDelegataList(); j++) {
  123.                     String azioneDelegata = portaDelegata.getAzione().getAzioneDelegata(j);
  124.                     if (azione.equals(azioneDelegata)) {
  125.                         portaDelegata.getAzione().removeAzioneDelegata(j);
  126.                         break;
  127.                     }
  128.                 }
  129.                 
  130.                 if(configAzioni!=null) {
  131.                     for (int j = 0; j < configAzioni.sizeAzioneList(); j++) {
  132.                         if(configAzioni.getAzione(j).equals(azione)) {
  133.                             configAzioni.removeAzione(j);
  134.                             updateASPS = true;
  135.                             break;
  136.                         }
  137.                     }
  138.                 }
  139.             }

  141.         }
  142.         
  143.         // non posso eliminare tutte le azioni
  144.         if(portaDelegata.getAzione().sizeAzioneDelegataList() == 0) {
  145.             inUsoMessage.append(PorteDelegateCostanti.MESSAGGIO_ERRORE_NON_E_POSSIBILE_ELIMINARE_TUTTE_LE_AZIONI_ASSOCIATE_ALLA_CONFIGURAZIONE); 
  146.         } 
  147.         else if(bfCT.length()>0) {
  148.             inUsoMessage.append("Non è stato possibile procedere con l'eliminazione poichè utilizzate in configurazione di Rate Limiting: "+bfCT.toString()); 
  149.         }
  150.         else if(bfTrasformazioni.length()>0) {
  151.             inUsoMessage.append("Non è stato possibile procedere con l'eliminazione poichè utilizzate in criteri di applicabilità di una Trasformazione: "+bfTrasformazioni.toString()); 
  152.         }
  153.         else {
  154.             
  155.             List<Object> listaOggettiDaModificare = new ArrayList<>();
  156.             
  157.             listaOggettiDaModificare.add(portaDelegata);
  158.             
  159.             if(updateASPS) {
  160.                 listaOggettiDaModificare.add(asps);
  161.             }
  162.             
  163.             porteDelegateCore.performUpdateOperation(userLogin, porteDelegateHelper.smista(), listaOggettiDaModificare.toArray());
  164.             
  165.         }
  166.         
  167.     }
  168.     
  169.     public static void initTracciamento(PortaDelegata pde, PorteDelegateCore porteDelegateCore, Configurazione config,
  170.             String tracciamentoStato, String statoDiagnostici, String severita) throws DriverConfigurazioneNotFound, DriverConfigurazioneException {
  171.         PortaTracciamento portaTracciamento = pde.getTracciamento();
  172.         if(portaTracciamento==null) {
  173.             portaTracciamento = new PortaTracciamento();
  174.             pde.setTracciamento(portaTracciamento);
  175.         }
  176.         
  177.         portaTracciamento.setStato(CostantiControlStation.VALUE_PARAMETRO_DUMP_STATO_RIDEFINITO.equals(tracciamentoStato) ? StatoFunzionalita.ABILITATO : StatoFunzionalita.DISABILITATO);
  178.         if(CostantiControlStation.VALUE_PARAMETRO_DUMP_STATO_RIDEFINITO.equals(tracciamentoStato)) {
  179.             if(config==null) {
  180.                 config = porteDelegateCore.getConfigurazioneGenerale();
  181.             }
  182.             if(config.getTracciamento()!=null && config.getTracciamento().getPortaDelegata()!=null) {
  183.                 portaTracciamento.setDatabase(config.getTracciamento().getPortaDelegata().getDatabase());
  184.                 portaTracciamento.setFiletrace(config.getTracciamento().getPortaDelegata().getFiletrace());
  185.                 if(portaTracciamento.getFiletrace()!=null && org.openspcoop2.core.config.constants.StatoFunzionalitaConPersonalizzazione.CONFIGURAZIONE_ESTERNA.equals(portaTracciamento.getFiletrace().getStato())) {
  186.                     portaTracciamento.getFiletrace().setStato(org.openspcoop2.core.config.constants.StatoFunzionalitaConPersonalizzazione.DISABILITATO);
  187.                 }
  188.                 portaTracciamento.setFiletraceConfig(config.getTracciamento().getPortaDelegata().getFiletraceConfig());
  189.                 portaTracciamento.setEsiti(config.getTracciamento().getPortaDelegata().getEsiti());
  190.                 portaTracciamento.setTransazioni(config.getTracciamento().getPortaDelegata().getTransazioni());
  191.             }
  192.         }
  193.         
  194.         if(CostantiControlStation.VALUE_PARAMETRO_DUMP_STATO_RIDEFINITO.equals(statoDiagnostici)) {
  195.             portaTracciamento.setSeverita(Severita.toEnumConstant(severita));
  196.         }
  197.         else {
  198.             portaTracciamento.setSeverita(null);
  199.         }
  200.     }
  201.     
  202.     public static void setTracciamentoTransazioni(PortaDelegata pde, PorteDelegateCore porteDelegateCore,
  203.             String dbStato,
  204.             String dbStatoReqIn, String dbStatoReqOut, String dbStatoResOut, String dbStatoResOutComplete,
  205.             boolean dbFiltroEsiti,
  206.             String fsStato,
  207.             String fsStatoReqIn, String fsStatoReqOut, String fsStatoResOut, String fsStatoResOutComplete,
  208.             boolean fsFiltroEsiti,
  209.             String nuovaConfigurazioneEsiti,
  210.             String transazioniTempiElaborazione, String transazioniToken,
  211.             String fileTraceStato, String fileTraceConfigFile,
  212.             String fileTraceClient, String fileTraceClientHdr, String fileTraceClientBody,
  213.             String fileTraceServer, String fileTraceServerHdr, String fileTraceServerBody) {
  214.         PortaTracciamento portaTracciamento = pde.getTracciamento();
  215.         if(portaTracciamento==null) {
  216.             portaTracciamento = new PortaTracciamento();
  217.             pde.setTracciamento(portaTracciamento);
  218.         }
  219.         
  220.         TracciamentoConfigurazione database = porteDelegateCore.buildTracciamentoConfigurazioneDatabase(dbStato,
  221.                 dbStatoReqIn, dbStatoReqOut, dbStatoResOut, dbStatoResOutComplete,
  222.                 dbFiltroEsiti);
  223.         portaTracciamento.setDatabase(database);
  224.         
  225.         TracciamentoConfigurazione filetrace = porteDelegateCore.buildTracciamentoConfigurazioneFiletrace(fsStato,
  226.                 fsStatoReqIn, fsStatoReqOut, fsStatoResOut, fsStatoResOutComplete,
  227.                 fsFiltroEsiti);
  228.         portaTracciamento.setFiletrace(filetrace);
  229.         
  230.         if(StringUtils.isEmpty(nuovaConfigurazioneEsiti)) {
  231.             portaTracciamento.setEsiti(EsitiConfigUtils.TUTTI_ESITI_DISABILITATI+"");
  232.         }
  233.         else {
  234.             portaTracciamento.setEsiti(nuovaConfigurazioneEsiti);
  235.         }
  236.         
  237.         if(portaTracciamento.getTransazioni()==null) {
  238.             portaTracciamento.setTransazioni( new Transazioni() );
  239.         }
  240.         portaTracciamento.getTransazioni().setTempiElaborazione(StatoFunzionalita.toEnumConstant(transazioniTempiElaborazione));
  241.         portaTracciamento.getTransazioni().setToken(StatoFunzionalita.toEnumConstant(transazioniToken));
  242.         
  243.         if(CostantiControlStation.VALUE_PARAMETRO_DUMP_STATO_RIDEFINITO.equals(fileTraceStato)) {
  244.             portaTracciamento.setFiletraceConfig(new TracciamentoConfigurazioneFiletrace());
  245.             portaTracciamento.getFiletraceConfig().setConfig(fileTraceConfigFile);
  246.             
  247.             portaTracciamento.getFiletraceConfig().setDumpIn(new TracciamentoConfigurazioneFiletraceConnector());           
  248.             portaTracciamento.getFiletraceConfig().getDumpIn().setStato(ConfigurazioneCostanti.DEFAULT_VALUE_ABILITATO.equals(fileTraceClient) ?
  249.                     StatoFunzionalita.ABILITATO : StatoFunzionalita.DISABILITATO);
  250.             portaTracciamento.getFiletraceConfig().getDumpIn().setHeader(ConfigurazioneCostanti.DEFAULT_VALUE_ABILITATO.equals(fileTraceClientHdr) ?
  251.                     StatoFunzionalita.ABILITATO : StatoFunzionalita.DISABILITATO);
  252.             portaTracciamento.getFiletraceConfig().getDumpIn().setPayload(ConfigurazioneCostanti.DEFAULT_VALUE_ABILITATO.equals(fileTraceClientBody) ?
  253.                     StatoFunzionalita.ABILITATO : StatoFunzionalita.DISABILITATO);
  254.             
  255.             portaTracciamento.getFiletraceConfig().setDumpOut(new TracciamentoConfigurazioneFiletraceConnector());          
  256.             portaTracciamento.getFiletraceConfig().getDumpOut().setStato(ConfigurazioneCostanti.DEFAULT_VALUE_ABILITATO.equals(fileTraceServer) ?
  257.                     StatoFunzionalita.ABILITATO : StatoFunzionalita.DISABILITATO);
  258.             portaTracciamento.getFiletraceConfig().getDumpOut().setHeader(ConfigurazioneCostanti.DEFAULT_VALUE_ABILITATO.equals(fileTraceServerHdr) ?
  259.                     StatoFunzionalita.ABILITATO : StatoFunzionalita.DISABILITATO);
  260.             portaTracciamento.getFiletraceConfig().getDumpOut().setPayload(ConfigurazioneCostanti.DEFAULT_VALUE_ABILITATO.equals(fileTraceServerBody) ?
  261.                     StatoFunzionalita.ABILITATO : StatoFunzionalita.DISABILITATO);
  262.         }
  263.         else {
  264.             portaTracciamento.setFiletraceConfig(null);
  265.         }
  266.     }
  267. }
Created with JaCoCo 0.8.8.202204050719