ConfigurazioneControlloTrafficoAttivazionePolicyAdd.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.  */
  20. package org.openspcoop2.web.ctrlstat.servlet.config;

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

  25. import javax.servlet.http.HttpServletRequest;
  26. import javax.servlet.http.HttpServletResponse;
  27. import javax.servlet.http.HttpSession;

  29. import org.apache.struts.action.Action;
  30. import org.apache.struts.action.ActionForm;
  31. import org.apache.struts.action.ActionForward;
  32. import org.apache.struts.action.ActionMapping;
  33. import org.openspcoop2.core.commons.Filtri;
  34. import org.openspcoop2.core.commons.Liste;
  35. import org.openspcoop2.core.config.PortaApplicativa;
  36. import org.openspcoop2.core.config.PortaDelegata;
  37. import org.openspcoop2.core.controllo_traffico.AttivazionePolicy;
  38. import org.openspcoop2.core.controllo_traffico.AttivazionePolicyFiltro;
  39. import org.openspcoop2.core.controllo_traffico.AttivazionePolicyRaggruppamento;
  40. import org.openspcoop2.core.controllo_traffico.beans.InfoPolicy;
  41. import org.openspcoop2.core.controllo_traffico.constants.RuoloPolicy;
  42. import org.openspcoop2.core.controllo_traffico.constants.TipoRisorsaPolicyAttiva;
  43. import org.openspcoop2.core.controllo_traffico.driver.PolicyGroupByActiveThreadsType;
  44. import org.openspcoop2.core.controllo_traffico.utils.ControlloTrafficoDriverUtils;
  45. import org.openspcoop2.core.id.IDPortaApplicativa;
  46. import org.openspcoop2.core.id.IDPortaDelegata;
  47. import org.openspcoop2.message.constants.ServiceBinding;
  48. import org.openspcoop2.pdd.core.controllo_traffico.policy.config.PolicyConfiguration;
  49. import org.openspcoop2.web.ctrlstat.core.ControlStationCore;
  50. import org.openspcoop2.web.ctrlstat.core.ConsoleSearch;
  51. import org.openspcoop2.web.ctrlstat.servlet.GeneralHelper;
  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.Costanti;
  56. import org.openspcoop2.web.lib.mvc.DataElement;
  57. import org.openspcoop2.web.lib.mvc.ForwardParams;
  58. import org.openspcoop2.web.lib.mvc.GeneralData;
  59. import org.openspcoop2.web.lib.mvc.PageData;
  60. import org.openspcoop2.web.lib.mvc.Parameter;
  61. import org.openspcoop2.web.lib.mvc.ServletUtils;
  62. import org.openspcoop2.web.lib.mvc.TipoOperazione;


  65. /**     
  66.  * ConfigurazioneControlloTrafficoAttivazionePolicyAdd
  67.  *
  68.  * @author Pintori Giuliano (pintori@link.it)
  69.  * @author $Author$
  70.  * @version $Rev$, $Date$
  71.  */
  72. public class ConfigurazioneControlloTrafficoAttivazionePolicyAdd extends Action {

  74.     @Override
  75.     public ActionForward execute(ActionMapping mapping, ActionForm form, HttpServletRequest request, HttpServletResponse response) throws Exception {

  77.         HttpSession session = request.getSession(true);

  79.         // Inizializzo PageData
  80.         PageData pd = new PageData();

  82.         GeneralHelper generalHelper = new GeneralHelper(session);

  84.         // Inizializzo GeneralData
  85.         GeneralData gd = generalHelper.initGeneralData(request);

  87.         String userLogin = ServletUtils.getUserLoginFromSession(session);   
  88.         
  89.         TipoOperazione tipoOperazione = TipoOperazione.ADD;

  91.         try {
  92.             StringBuilder sbParsingError = new StringBuilder();
  93.             
  94.             ConfigurazioneHelper confHelper = new ConfigurazioneHelper(request, pd, session);
  95.             
  96.             ConfigurazioneCore confCore = new ConfigurazioneCore();
  97.             SoggettiCore soggettiCore = new SoggettiCore(confCore);
  98.             PorteDelegateCore pdCore = new PorteDelegateCore(confCore);
  99.             PorteApplicativeCore paCore = new PorteApplicativeCore(confCore);
  100.             
  101.             org.openspcoop2.core.controllo_traffico.ConfigurazioneGenerale configurazioneControlloTraffico = confCore.getConfigurazioneControlloTraffico();
  102.             
  103.             AttivazionePolicy policy = new AttivazionePolicy();
  104.             policy.setFiltro(new AttivazionePolicyFiltro());
  105.             policy.getFiltro().setRuoloPorta(RuoloPolicy.ENTRAMBI);
  106.             policy.setGroupBy(new AttivazionePolicyRaggruppamento());
  107.             
  108.             // uso nome porta per capire se sono entrato per la prima volta nella schermata
  109.             boolean first = confHelper.isFirstTimeFromHttpParameters(ConfigurazioneCostanti.PARAMETRO_CONFIGURAZIONE_CONTROLLO_TRAFFICO_FIRST_TIME);
  110.             
  111.             String ruoloPortaParam = confHelper.getParameter(ConfigurazioneCostanti.PARAMETRO_CONFIGURAZIONE_CONTROLLO_TRAFFICO_RATE_LIMITING_POLICY_GLOBALI_LINK_RUOLO_PORTA);
  112.             RuoloPolicy ruoloPorta = null;
  113.             if(ruoloPortaParam!=null) {
  114.                 ruoloPorta = RuoloPolicy.toEnumConstant(ruoloPortaParam);
  115.             }
  116.             String nomePorta = confHelper.getParameter(ConfigurazioneCostanti.PARAMETRO_CONFIGURAZIONE_CONTROLLO_TRAFFICO_RATE_LIMITING_POLICY_GLOBALI_LINK_NOME_PORTA);
  117.             ServiceBinding serviceBinding = null;
  118.             String serviceBindingParam = confHelper.getParameter(ConfigurazioneCostanti.PARAMETRO_CONFIGURAZIONE_CONTROLLO_TRAFFICO_RATE_LIMITING_POLICY_GLOBALI_LINK_SERVICE_BINDING);
  119.             if(serviceBindingParam!=null && !"".equals(serviceBindingParam)) {
  120.                 serviceBinding = ServiceBinding.valueOf(serviceBindingParam);
  121.             }
  122.             
  123.             String modalita = confHelper.getParameter(ConfigurazioneCostanti.PARAMETRO_CONFIGURAZIONE_CONTROLLO_TRAFFICO_POLICY_ACTIVE_POLICY_MODALITA);
  124.             if(modalita==null) {
  125.                 modalita = ConfigurazioneCostanti.PARAMETRO_CONFIGURAZIONE_CONTROLLO_TRAFFICO_POLICY_ACTIVE_POLICY_MODALITA_DEFAULT;
  126.             }
  127.             boolean builtIn = ConfigurazioneCostanti.PARAMETRO_CONFIGURAZIONE_CONTROLLO_TRAFFICO_POLICY_ACTIVE_POLICY_MODALITA_BUILT_IN.equals(modalita);
  128.             
  129.             // nome della Policy
  130.             String idPolicy = confHelper.getParameter(ConfigurazioneCostanti.PARAMETRO_CONFIGURAZIONE_CONTROLLO_TRAFFICO_POLICY_ACTIVE_POLICY_ID);
  131.             if(idPolicy!=null && !"".equals(idPolicy) && !"-".equals(idPolicy)){
  132.                 policy.setIdPolicy(idPolicy);
  133.             }
  134.             else{
  135.                 if(!first){
  136.                     policy.setIdPolicy(null);
  137.                 }
  138.             }   
  139.             
  140.             InfoPolicy infoPolicy = null;
  141.             if(policy.getIdPolicy()!=null){
  142.                 infoPolicy = confCore.getInfoPolicy(policy.getIdPolicy());
  143.                 
  144.                 if(TipoOperazione.ADD.equals(tipoOperazione) && infoPolicy!=null){
  145.                     String serialId = confCore.getNextPolicyInstanceSerialId(infoPolicy.getIdPolicy());
  146.                     policy.setIdActivePolicy(ControlloTrafficoDriverUtils.buildIdActivePolicy(infoPolicy.getIdPolicy(), serialId));
  147.                 }
  148.             }
  149.             
  150.             // Dati Attivazione
  151.             String errorAttivazione = confHelper.readDatiAttivazionePolicyFromHttpParameters(policy, first, tipoOperazione, infoPolicy);
  152.             if(errorAttivazione!=null){
  153.                 confHelper.addParsingError(sbParsingError,errorAttivazione); 
  154.             }
  155.             
  156.             PolicyGroupByActiveThreadsType type = null;
  157.             
  158.             if(ruoloPorta!=null) {
  159.                 
  160.                 String protocollo = null;
  161.                 String tipoSoggettoProprietario = null;
  162.                 String nomeSoggettoProprietario = null;
  163.                 if(RuoloPolicy.DELEGATA.equals(ruoloPorta)) {
  164.                     IDPortaDelegata idPD = new IDPortaDelegata();
  165.                     idPD.setNome(nomePorta);
  166.                     PortaDelegata porta = pdCore.getPortaDelegata(idPD);
  167.                     protocollo = soggettiCore.getProtocolloAssociatoTipoSoggetto(porta.getTipoSoggettoProprietario());
  168.                     // il tipo e nome serve per l'applicativo fruitore
  169.                     tipoSoggettoProprietario = porta.getTipoSoggettoProprietario();
  170.                     nomeSoggettoProprietario = porta.getNomeSoggettoProprietario();
  171.                     // tipo
  172.                     PolicyConfiguration config = new PolicyConfiguration(porta.getProprietaRateLimitingList(), confCore.getControlloTrafficoPolicyRateLimitingTipiGestori(), false);
  173.                     type = config.getType();
  174.                 }
  175.                 else {
  176.                     IDPortaApplicativa idPA = new IDPortaApplicativa();
  177.                     idPA.setNome(nomePorta);
  178.                     PortaApplicativa porta = paCore.getPortaApplicativa(idPA);
  179.                     protocollo = soggettiCore.getProtocolloAssociatoTipoSoggetto(porta.getTipoSoggettoProprietario());
  180.                     // tipo
  181.                     PolicyConfiguration config = new PolicyConfiguration(porta.getProprietaRateLimitingList(), confCore.getControlloTrafficoPolicyRateLimitingTipiGestori(), false);
  182.                     type = config.getType();
  183.                 }
  184.                 
  185.                 policy.getFiltro().setEnabled(true);
  186.                 policy.getFiltro().setProtocollo(protocollo);
  187.                 policy.getFiltro().setRuoloPorta(ruoloPorta);
  188.                 policy.getFiltro().setNomePorta(nomePorta);
  189.                 if(RuoloPolicy.DELEGATA.equals(ruoloPorta)) {
  190.                     policy.getFiltro().setTipoFruitore(tipoSoggettoProprietario);
  191.                     policy.getFiltro().setNomeFruitore(nomeSoggettoProprietario);
  192.                 }
  193.                 
  194.                 // verifico rispetto alla configurazione globale
  195.                 if(type==null) {
  196.                     PolicyConfiguration pc = confCore.getConfigurazioneControlloTrafficoRateLimitingProperties();
  197.                     if(pc!=null) {
  198.                         type = pc.getType();
  199.                     }
  200.                 }
  201.             }
  202.             else {
  203.                 PolicyConfiguration pc = confCore.getConfigurazioneControlloTrafficoRateLimitingProperties();
  204.                 if(pc!=null) {
  205.                     type = pc.getType();
  206.                 }
  207.             }
  208.             
  209.             
  210.             // Preparo il menu
  211.             confHelper.makeMenu();
  212.             
  213.             // setto la barra del titolo
  214.             
  215.             List<Parameter> lstParamPorta = null;
  216.             if(ruoloPorta!=null) {
  217.                 lstParamPorta = confHelper.getTitleListAttivazionePolicy(ruoloPorta, nomePorta, serviceBinding, Costanti.PAGE_DATA_TITLE_LABEL_AGGIUNGI);
  218.             }
  219.             
  220.             List<Parameter> lstParam = null;
  221.             if(lstParamPorta!=null) {
  222.                 lstParam = lstParamPorta;
  223.             }
  224.             else {
  225.                 lstParam = new ArrayList<>();
  226.                 lstParam.add(new Parameter(ConfigurazioneCostanti.LABEL_CONFIGURAZIONE_CONTROLLO_TRAFFICO, ConfigurazioneCostanti.SERVLET_NAME_CONFIGURAZIONE_CONTROLLO_TRAFFICO));
  227.                 lstParam.add(new Parameter(ConfigurazioneCostanti.LABEL_PARAMETRO_CONFIGURAZIONE_CONTROLLO_TRAFFICO_RATE_LIMITING_POLICY_GLOBALI_LINK, ConfigurazioneCostanti.SERVLET_NAME_CONFIGURAZIONE_CONTROLLO_TRAFFICO_ATTIVAZIONE_POLICY_LIST));
  228.                 lstParam.add(ServletUtils.getParameterAggiungi());
  229.             }
  230.             
  231.             List<InfoPolicy> infoPolicies = confCore.infoPolicyList(builtIn);
  232.             
  233.             // Se tipo = null, devo visualizzare la pagina per l'inserimento
  234.             // dati
  235.             if (confHelper.isEditModeInProgress()) {
  236.                 ServletUtils.setPageDataTitle(pd, lstParam);
  237.                 
  238.                 // preparo i campi
  239.                 List<DataElement> dati = new ArrayList<>();
  240.                 dati.add(ServletUtils.getDataElementForEditModeFinished());
  241.                 
  242.                 // Controllo spostato dentro addAttivazionePolicyToDati
  243.                 /**
  244. //              if(infoPolicies==null || infoPolicies.size()<=0){
  245. //                  pd.setMessage(ConfigurazioneCostanti.LABEL_CONFIGURAZIONE_POLICY_POSSIBILI_COMPLETATE_GLOBALI, MessageType.INFO);
  246. //                  pd.disableEditMode();
  247. //                  pd.setDati(dati);
  248. //          
  249. //                  ServletUtils.setGeneralAndPageDataIntoSession(request, session, gd, pd);
  250. //
  251. //                  return ServletUtils.getStrutsForwardEditModeInProgress(mapping, ConfigurazioneCostanti.OBJECT_NAME_CONFIGURAZIONE_CONTROLLO_TRAFFICO_ATTIVAZIONE_POLICY,    ForwardParams.ADD());
  252. //              }*/
  253.                 
  254.                 // Attivazione
  255.                 confHelper.addAttivazionePolicyToDati(dati, tipoOperazione, policy,ConfigurazioneCostanti.LABEL_CONFIGURAZIONE_POLICY, infoPolicies, ruoloPorta, nomePorta, serviceBinding, modalita, type);
  256.                 
  257.                 // Set First is false
  258.                 confHelper.addToDatiFirstTimeDisabled(dati,ConfigurazioneCostanti.PARAMETRO_CONFIGURAZIONE_CONTROLLO_TRAFFICO_FIRST_TIME);
  259.                 
  260.                 pd.setDati(dati);

  262.                 ServletUtils.setGeneralAndPageDataIntoSession(request, session, gd, pd);

  264.                 return ServletUtils.getStrutsForwardEditModeInProgress(mapping,
  265.                         ConfigurazioneCostanti.OBJECT_NAME_CONFIGURAZIONE_CONTROLLO_TRAFFICO_ATTIVAZIONE_POLICY, 
  266.                         ForwardParams.ADD());
  267.             }
  268.             
  269.             // Controlli sui campi immessi
  270.             boolean isOk = confHelper.attivazionePolicyCheckData(sbParsingError, tipoOperazione, configurazioneControlloTraffico, 
  271.                     policy,infoPolicy, ruoloPorta, nomePorta, serviceBinding, modalita);
  272.             if (!isOk) {
  273.                 
  274.                 ServletUtils.setPageDataTitle(pd, lstParam);
  275.                 
  276.                 // preparo i campi
  277.                 List<DataElement> dati = new ArrayList<>();
  278.                 dati.add(ServletUtils.getDataElementForEditModeFinished());
  279.                 
  280.                 // Attivazione
  281.                 confHelper.addAttivazionePolicyToDati(dati, tipoOperazione, policy,ConfigurazioneCostanti.LABEL_CONFIGURAZIONE_POLICY, infoPolicies, ruoloPorta, nomePorta, serviceBinding, modalita, type);
  282.                 
  283.                 // Set First is false
  284.                 confHelper.addToDatiFirstTimeDisabled(dati,ConfigurazioneCostanti.PARAMETRO_CONFIGURAZIONE_CONTROLLO_TRAFFICO_FIRST_TIME);
  285.                 
  286.                 pd.setDati(dati);

  288.                 ServletUtils.setGeneralAndPageDataIntoSession(request, session, gd, pd);
  289.                 
  290.                 return ServletUtils.getStrutsForwardEditModeCheckError(mapping, 
  291.                         ConfigurazioneCostanti.OBJECT_NAME_CONFIGURAZIONE_CONTROLLO_TRAFFICO_ATTIVAZIONE_POLICY, 
  292.                         ForwardParams.ADD());
  293.             }

  295.             
  296.             // aggiorno prossima posizione nella policy
  297.             ConfigurazioneUtilities.updatePosizioneAttivazionePolicy(confCore, infoPolicy, policy, ruoloPorta, nomePorta);
  298.             
  299.             // insert sul db
  300.             confCore.performCreateOperation(userLogin, confHelper.smista(), policy);
  301.             
  302.             String msgCompletato = confHelper.eseguiResetJmx(TipoOperazione.ADD, ruoloPorta, nomePorta);
  303.             if(msgCompletato!=null && !"".equals(msgCompletato)){
  304.                 pd.setMessage(msgCompletato,Costanti.MESSAGE_TYPE_INFO);
  305.             }
  306.             
  307.             // Preparo la lista
  308.             int idLista = Liste.CONFIGURAZIONE_CONTROLLO_TRAFFICO_ATTIVAZIONE_POLICY;
  309.             
  310.             ConsoleSearch ricerca = (ConsoleSearch) ServletUtils.getSearchObjectFromSession(request, session, ConsoleSearch.class);
  311.             
  312.             ricerca = confHelper.checkSearchParameters(idLista, ricerca);

  314.             List<TipoRisorsaPolicyAttiva> listaTipoRisorsa = 
  315.                     confHelper.gestisciCriteriFiltroRisorsaPolicy(ricerca, ruoloPorta, nomePorta);
  316.             
  317.             // imposto come filtro il tipo di risorsa creata in modo da vederlo subito nella lista
  318.             ricerca.addFilter(idLista, Filtri.FILTRO_TIPO_RISORSA_POLICY, infoPolicy.getTipoRisorsa().getValue());
  319.             
  320.             List<AttivazionePolicy> lista = confCore.attivazionePolicyList(ricerca, ruoloPorta, nomePorta);
  321.             
  322.             confHelper.prepareAttivazionePolicyList(ricerca, lista, listaTipoRisorsa,
  323.                     idLista, ruoloPorta, nomePorta, serviceBinding); 
  324.             
  325.             // salvo l'oggetto ricerca nella sessione
  326.             ServletUtils.setSearchObjectIntoSession(request, session, ricerca);
  327.             ServletUtils.setGeneralAndPageDataIntoSession(request, session, gd, pd);
  328.             
  329.             // Forward control to the specified success URI
  330.             return ServletUtils.getStrutsForwardEditModeFinished(mapping, ConfigurazioneCostanti.OBJECT_NAME_CONFIGURAZIONE_CONTROLLO_TRAFFICO_ATTIVAZIONE_POLICY, ForwardParams.ADD());
  331.         } catch (Exception e) {
  332.             return ServletUtils.getStrutsForwardError(ControlStationCore.getLog(), e, pd, request, session, gd, mapping, 
  333.                     ConfigurazioneCostanti.OBJECT_NAME_CONFIGURAZIONE_CONTROLLO_TRAFFICO_ATTIVAZIONE_POLICY, ForwardParams.ADD());
  334.         }  
  335.     }
  336. }
Created with JaCoCo 0.8.8.202204050719