StatisticsServiceLibrary.java

/*
 * GovWay - A customizable API Gateway 
 * https://govway.org
 * 
 * Copyright (c) 2005-2025 Link.it srl (https://link.it).
 * 
 * This program is free software: you can redistribute it and/or modify
 * it under the terms of the GNU General Public License version 3, as published by
 * the Free Software Foundation.
 *
 * This program is distributed in the hope that it will be useful,
 * but WITHOUT ANY WARRANTY; without even the implied warranty of
 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
 * GNU General Public License for more details.
 *
 * You should have received a copy of the GNU General Public License
 * along with this program.  If not, see <http://www.gnu.org/licenses/>.
 *
 */
package org.openspcoop2.monitor.engine.config;

import java.io.Serializable;
import java.util.ArrayList;
import java.util.Collections;
import java.util.HashMap;
import java.util.List;
import java.util.Map;

import org.openspcoop2.core.plugins.constants.TipoPlugin;
import org.openspcoop2.monitor.engine.config.statistiche.ConfigurazioneStatistica;
import org.openspcoop2.monitor.engine.config.statistiche.InfoPlugin;
import org.openspcoop2.monitor.engine.statistic.StatisticByResource;
import org.openspcoop2.monitor.engine.statistic.StatisticByState;

/**
 * StatisticsServiceLibrary
 *
 * @author Poli Andrea (apoli@link.it)
 * @author $Author$
 * @version $Rev$, $Date$
 */
public class StatisticsServiceLibrary implements Serializable {

    /**
     * 
     */
    private static final long serialVersionUID = 1L;

    private BasicServiceLibrary basicServiceLibrary;
    private List<ConfigurazioneStatistica> statisticsActionLibrary;
    private List<ConfigurazioneStatistica> statisticsActionAllLibrary;
    private boolean pluginStatiTransazioniEnabled = false; // plugin org.openspcoop2.monitor.engine.plugins.statistic.StatisticByState
    private List<String> pluginRisorseTransazioni = new ArrayList<>(); // plugin org.openspcoop2.monitor.engine.plugins.statistic.StatisticByResource

    public BasicServiceLibrary getBasicServiceLibrary() {
        return this.basicServiceLibrary;
    }
    public void setBasicServiceLibrary(BasicServiceLibrary basicServiceLibrary) {
        this.basicServiceLibrary = basicServiceLibrary;
    }
    public List<ConfigurazioneStatistica> getStatisticsActionLibrary() {
        return this.statisticsActionLibrary;
    }
    public void setStatisticsActionLibrary(List<ConfigurazioneStatistica> searchActionLibrary) {
        this.statisticsActionLibrary = searchActionLibrary;
    }
    public List<ConfigurazioneStatistica> getStatisticsActionAllLibrary() {
        return this.statisticsActionAllLibrary;
    }
    public void setStatisticsActionAllLibrary(
            List<ConfigurazioneStatistica> searchActionAllLibrary) {
        this.statisticsActionAllLibrary = searchActionAllLibrary;
    }
    public boolean isPluginStatiTransazioniEnabled() {
        return this.pluginStatiTransazioniEnabled;
    }
    public void setPluginStatiTransazioniEnabled(boolean pluginStatiTransazioniEnabled) {
        this.pluginStatiTransazioniEnabled = pluginStatiTransazioniEnabled;
    }
    public List<String> getPluginRisorseTransazioni() {
        return this.pluginRisorseTransazioni;
    }
    public void setPluginRisorseTransazioni(List<String> pluginRisorseTransazioni) {
        this.pluginRisorseTransazioni = pluginRisorseTransazioni;
    }



    // ****** UTILS *************** 

    @Override
    public String toString(){
        StringBuilder bf = new StringBuilder();

        if(this.basicServiceLibrary==null){
            bf.append("BasicServiceLibrary: notDefined");
            bf.append("\n");
        }
        else{
            bf.append(this.basicServiceLibrary.toString());
        }

            
        if(this.getStatisticsActionLibrary()!=null){
            for (int i = 0; i < this.getStatisticsActionLibrary().size(); i++) {
                bf.append("StatisticsActionLibrary["+i+"]: ");
                bf.append("id[").
                append(this.getStatisticsActionLibrary().get(i).getIdConfigurazioneStatistica()).
                append("] plugin.className[").
                append(this.getStatisticsActionLibrary().get(i).getPlugin().getClassName()).
                append("] plugin.description[").
                append(this.getStatisticsActionLibrary().get(i).getPlugin().getDescrizione()).
                append("] plugin.label[").
                append(this.getStatisticsActionLibrary().get(i).getPlugin().getLabel()).
                append("] label[").
                append(this.getStatisticsActionLibrary().get(i).getLabel()).
                append("] enabled[").
                append(this.getStatisticsActionLibrary().get(i).isEnabled()).
                append("]");
                bf.append("\n");
            }
        }else{
            bf.append("StatisticsActionLibrary: ");
            bf.append("-");
        }
        bf.append("\n");

        
        if(this.getStatisticsActionAllLibrary()!=null){
            for (int i = 0; i < this.getStatisticsActionAllLibrary().size(); i++) {
                bf.append("StatisticsActionAllLibrary["+i+"]: ");
                bf.append("id[").
                append(this.getStatisticsActionAllLibrary().get(i).getIdConfigurazioneStatistica()).
                append("] plugin.className[").
                append(this.getStatisticsActionAllLibrary().get(i).getPlugin().getClassName()).
                append("] plugin.description[").
                append(this.getStatisticsActionAllLibrary().get(i).getPlugin().getDescrizione()).
                append("] plugin.label[").
                append(this.getStatisticsActionAllLibrary().get(i).getPlugin().getLabel()).
                append("] label[").
                append(this.getStatisticsActionAllLibrary().get(i).getLabel()).
                append("] enabled[").
                append(this.getStatisticsActionAllLibrary().get(i).isEnabled()).
                append("]");
                bf.append("\n");
            }
        }else{
            bf.append("StatisticsActionAllLibrary: ");
            bf.append("-");
        }
        bf.append("\n");


        return bf.toString();
    }


    public List<ConfigurazioneStatistica> mergeServiceActionSearchLibrary(boolean onlyEnabled, boolean orderByLabel) throws Exception{

        Map<String,ConfigurazioneStatistica> plugins = new HashMap<String,ConfigurazioneStatistica>();

        if(this.pluginStatiTransazioniEnabled){
            ConfigurazioneStatistica conf = this.buildNewConfigurazioneStatistica(StatisticByState.ID, StatisticByState.LABEL, 
                    StatisticByState.DESCRIZIONE,StatisticByState.class);
            plugins.put(conf.getPlugin().getClassName(), conf);
        }
        
        if(this.pluginRisorseTransazioni!=null && this.pluginRisorseTransazioni.size()>0){
            ConfigurazioneStatistica conf = this.buildNewConfigurazioneStatistica(StatisticByResource.ID, StatisticByResource.LABEL, 
                    StatisticByResource.DESCRIZIONE,StatisticByResource.class);
            plugins.put(conf.getPlugin().getClassName(), conf);
        }
        
        // Leggo le risorse associate all'azione specifica
        if(this.statisticsActionLibrary!=null && this.statisticsActionLibrary.size()>0){
            for (ConfigurazioneStatistica configurazioneStatistica : this.statisticsActionLibrary) {
                if(!onlyEnabled || configurazioneStatistica.isEnabled()){
                    plugins.put(configurazioneStatistica.getPlugin().getClassName(), configurazioneStatistica);
                }
            }
        }

        // Leggo le risorse associate all'azione '*'
        if(this.statisticsActionAllLibrary!=null && this.statisticsActionAllLibrary.size()>0){
            for (ConfigurazioneStatistica configurazioneStatistica : this.statisticsActionAllLibrary) {

                String idRisorsa = configurazioneStatistica.getPlugin().getClassName();
                if(plugins.containsKey(idRisorsa)==false){

                    // inserisco solo le risorse il cui idPlugin non siano già stati inseriti per l'azione specifica

                    if(!onlyEnabled || configurazioneStatistica.isEnabled()){
                        plugins.put(configurazioneStatistica.getPlugin().getClassName(), configurazioneStatistica);
                    }
                }

            }
        }

        List<ConfigurazioneStatistica> list = new ArrayList<ConfigurazioneStatistica>();
        if(orderByLabel){
            List<String> sortedKey = new ArrayList<>();
            Map<String, ConfigurazioneStatistica> mapLabelToCorrelazioneStatistica = new HashMap<String, ConfigurazioneStatistica>();
            int count = 0; // lo uso per gestire eventuali label identiche.
            for (String className : plugins.keySet()) {
                ConfigurazioneStatistica cs = plugins.get(className);
                String labelKey = cs.getLabel()+count;
                sortedKey.add(labelKey);
                mapLabelToCorrelazioneStatistica.put(labelKey, cs);
                count++;
            }
            Collections.sort(sortedKey);
            for (String sortKey : sortedKey) {
                list.add(mapLabelToCorrelazioneStatistica.get(sortKey));
            }
        }
        else{
            list.addAll(plugins.values());
        }
        return list;
    }
    

    private ConfigurazioneStatistica buildNewConfigurazioneStatistica(String id,String label,String descrizione,Class<?> classPlugin){
        ConfigurazioneStatistica conf = new ConfigurazioneStatistica();
        conf.setEnabled(true);
        conf.setIdConfigurazioneStatistica(id);
        conf.setLabel(label);
        InfoPlugin infoPlugin = new InfoPlugin();
        infoPlugin.setClassName(classPlugin.getName());
        infoPlugin.setDescrizione(descrizione);
        infoPlugin.setLabel(label);
        infoPlugin.setTipo(TipoPlugin.STATISTICA.getValue());
        conf.setPlugin(infoPlugin);
        return conf;
    }
}