ConfigurazionePdD_plugins.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.List;

  26. import org.openspcoop2.core.commons.Filtri;
  27. import org.openspcoop2.core.commons.dao.DAOFactory;
  28. import org.openspcoop2.core.config.driver.DriverConfigurazioneException;
  29. import org.openspcoop2.core.config.driver.DriverConfigurazioneNotFound;
  30. import org.openspcoop2.core.config.driver.db.DriverConfigurazioneDB;
  31. import org.openspcoop2.generic_project.exception.NotFoundException;
  32. import org.openspcoop2.generic_project.expression.IExpression;
  33. import org.openspcoop2.generic_project.expression.IPaginatedExpression;
  34. import org.openspcoop2.generic_project.utils.ServiceManagerProperties;
  35. import org.openspcoop2.core.plugins.IdPlugin;
  36. import org.openspcoop2.core.plugins.Plugin;
  37. import org.openspcoop2.core.plugins.PluginProprietaCompatibilita;
  38. import org.openspcoop2.core.plugins.dao.IPluginServiceSearch;
  39. import org.openspcoop2.pdd.logger.OpenSPCoop2Logger;
  40. import org.openspcoop2.utils.NameValue;

  42. /**     
  43.  * ConfigurazionePdD_plugins
  44.  *
  45.  * @author Poli Andrea (poli@link.it)
  46.  * @author $Author$
  47.  * @version $Rev$, $Date$
  48.  */
  49. public class ConfigurazionePdD_plugins extends AbstractConfigurazionePdDConnectionResourceManager {

  51.     private ServiceManagerProperties smp;
  52.     
  53.     
  54.     public ConfigurazionePdD_plugins(OpenSPCoop2Properties openspcoopProperties, DriverConfigurazioneDB driver, boolean useConnectionPdD) {
  55.         super(openspcoopProperties, driver, useConnectionPdD, OpenSPCoop2Logger.getLoggerOpenSPCoopPluginsSql(openspcoopProperties.isConfigurazionePluginsDebug()));
  56.         
  57.         this.smp = new ServiceManagerProperties();
  58.         this.smp.setShowSql(this.openspcoopProperties.isConfigurazionePluginsDebug());
  59.         this.smp.setDatabaseType(this.driver.getTipoDB());
  60.     }
  61.     
  62.     
  63.     
  64.     
  65.     public int countPlugins(Connection connectionPdD) throws DriverConfigurazioneException{
  66.         
  67.         ConfigurazionePdDConnectionResource cr = null;
  68.         try{
  69.             cr = this.getConnection(connectionPdD, "Plugins.countPlugins");
  70.             org.openspcoop2.core.plugins.dao.IServiceManager sm = 
  71.                     (org.openspcoop2.core.plugins.dao.IServiceManager) DAOFactory.getInstance(this.log).
  72.                     getServiceManager(org.openspcoop2.core.plugins.utils.ProjectInfo.getInstance(),
  73.                             cr.connectionDB,this.smp,this.log);
  74.             
  75.             IPluginServiceSearch search =  sm.getPluginServiceSearch();
  76.             IExpression expr = search.newExpression();
  77.             return (int) search.count(expr).longValue();
  78.         }
  79.         catch(Exception e){
  80.             String errorMsg = "Errore durante la conta dei plugins registrati: "+e.getMessage();
  81.             this.log.error(errorMsg,e);
  82.             throw new DriverConfigurazioneException(errorMsg,e);
  83.         }
  84.         finally {
  85.             this.releaseConnection(cr);
  86.         }

  88.     }
  89.     
  90.     public List<IdPlugin> findAllPluginIds(Connection connectionPdD, int offset, int limit) throws DriverConfigurazioneException{
  91.         
  92.         ConfigurazionePdDConnectionResource cr = null;
  93.         try{
  94.             cr = this.getConnection(connectionPdD, "Plugins.findAllPluginIds_"+offset+"_"+limit);
  95.             org.openspcoop2.core.plugins.dao.IServiceManager sm = 
  96.                     (org.openspcoop2.core.plugins.dao.IServiceManager) DAOFactory.getInstance(this.log).
  97.                     getServiceManager(org.openspcoop2.core.plugins.utils.ProjectInfo.getInstance(),
  98.                             cr.connectionDB,this.smp,this.log);
  99.             
  100.             IPluginServiceSearch search =  sm.getPluginServiceSearch();
  101.             IPaginatedExpression pagExpr = search.newPaginatedExpression();
  102.             pagExpr.offset(offset);
  103.             pagExpr.limit(limit);
  104.             pagExpr.addOrder(Plugin.model().TIPO_PLUGIN);
  105.             pagExpr.addOrder(Plugin.model().TIPO);
  106.             return search.findAllIds(pagExpr);
  107.         }
  108.         catch(Exception e){
  109.             String errorMsg = "Errore durante la lettura degli idPlugin (offset:"+offset+" limit:"+limit+"): "+e.getMessage();
  110.             this.log.error(errorMsg,e);
  111.             throw new DriverConfigurazioneException(errorMsg,e);
  112.         }
  113.         finally {
  114.             this.releaseConnection(cr);
  115.         }

  117.     }
  118.     
  119.     
  120.     
  121.     public String getPluginClassName(Connection connectionPdD, String tipoPlugin, String tipo) throws DriverConfigurazioneException, DriverConfigurazioneNotFound{
  122.         return getPluginClassNameByFilter(connectionPdD, tipoPlugin, tipo);
  123.     }
  124.     public String getPluginClassNameByFilter(Connection connectionPdD, String tipoPlugin, String tipo, NameValue ... filtri) throws DriverConfigurazioneException, DriverConfigurazioneNotFound{
  125.         
  126.         if(tipoPlugin==null || "".equals(tipoPlugin)) {
  127.             throw new DriverConfigurazioneException("tipo plugin non fornito");
  128.         }
  129.         if(tipo==null || "".equals(tipo)) {
  130.             throw new DriverConfigurazioneException("tipo non fornito");
  131.         }
  132.         
  133.         ConfigurazionePdDConnectionResource cr = null;
  134.         try{
  135.             cr = this.getConnection(connectionPdD, "Plugins.getPluginClassName_"+tipoPlugin+"#"+tipo);
  136.             org.openspcoop2.core.plugins.dao.IServiceManager sm = 
  137.                     (org.openspcoop2.core.plugins.dao.IServiceManager) DAOFactory.getInstance(this.log).
  138.                     getServiceManager(org.openspcoop2.core.plugins.utils.ProjectInfo.getInstance(),
  139.                             cr.connectionDB,this.smp,this.log);
  140.             
  141.             IPluginServiceSearch search =  sm.getPluginServiceSearch();
  142.             IdPlugin idPlugin = new IdPlugin();
  143.             idPlugin.setTipoPlugin(tipoPlugin);
  144.             idPlugin.setTipo(tipo);
  145.             
  146.             Plugin plugin = search.get(idPlugin);
  147.             
  148.             if(filtri!=null && filtri.length>0) {
  149.                 for (int i = 0; i < filtri.length; i++) {
  150.                     NameValue filtro = filtri[i];
  151.                     
  152.                     if(plugin.sizePluginProprietaCompatibilitaList()>0) {
  153.                         for (int j = 0; j < plugin.sizePluginProprietaCompatibilitaList(); j++) {
  154.                             PluginProprietaCompatibilita ppc = plugin.getPluginProprietaCompatibilita(j);
  155.                             if(ppc.getNome().equals(filtro.getName())) {
  156.                                 if(!ppc.getValore().equals(filtro.getValue())) {
  157.                                     
  158.                                     // gestisco caso speciale
  159.                                     boolean isCasoSpecialeQualsiasi = false;
  160.                                     
  161.                                     if(Filtri.FILTRO_RUOLO_NOME.equals(ppc.getNome()) && Filtri.FILTRO_RUOLO_VALORE_ENTRAMBI.equals(ppc.getValore())) {
  162.                                         isCasoSpecialeQualsiasi = true;
  163.                                     }
  164.                                     
  165.                                     if(Filtri.FILTRO_APPLICABILITA_NOME.equals(ppc.getNome())) {
  166.                                         if(Filtri.FILTRO_APPLICABILITA_VALORE_QUALSIASI.equals(ppc.getValore())) {
  167.                                             isCasoSpecialeQualsiasi = true;
  168.                                         }
  169.                                         else if(Filtri.FILTRO_APPLICABILITA_VALORE_FRUIZIONE.equals(filtro.getValue()) && Filtri.FILTRO_APPLICABILITA_VALORE_IMPLEMENTAZIONE_API.equals(ppc.getValore())) {
  170.                                             isCasoSpecialeQualsiasi = true;
  171.                                         } 
  172.                                         else if(Filtri.FILTRO_APPLICABILITA_VALORE_EROGAZIONE.equals(filtro.getValue()) && Filtri.FILTRO_APPLICABILITA_VALORE_IMPLEMENTAZIONE_API.equals(ppc.getValore())) {
  173.                                             isCasoSpecialeQualsiasi = true;
  174.                                         } 
  175.                                     }
  176.                                     
  177.                                     if(!isCasoSpecialeQualsiasi) {                                  
  178.                                         throw new NotFoundException("Filtro '"+ppc.getNome()+"' non soddisfatto (atteso:"+filtro.getValue()+" trovato:"+ppc.getValore()+")");
  179.                                     }
  180.                                 }
  181.                             }
  182.                         }
  183.                     }
  184.                     
  185.                 }
  186.             }
  187.             
  188.             return plugin.getClassName();

  190.         }
  191.         catch(NotFoundException e) {
  192.             String errorMsg = "Plugin (tipologia:"+tipoPlugin+" tipo:"+tipo+") non trovato: "+e.getMessage();
  193.             this.log.debug(errorMsg,e);
  194.             throw new DriverConfigurazioneNotFound(errorMsg,e);
  195.         }
  196.         catch(Exception e){
  197.             String errorMsg = "Errore durante la lettura del Plugin (tipologia:"+tipoPlugin+" tipo:"+tipo+"): "+e.getMessage();
  198.             this.log.error(errorMsg,e);
  199.             throw new DriverConfigurazioneException(errorMsg,e);
  200.         }
  201.         finally {
  202.             this.releaseConnection(cr);
  203.         }

  205.     }
  206.     
  207.     
  208.     public String getPluginTipo(Connection connectionPdD, String tipoPlugin, String className) throws DriverConfigurazioneException, DriverConfigurazioneNotFound{
  209.         return getPluginTipoByFilter(connectionPdD, tipoPlugin, className);
  210.     }
  211.     public String getPluginTipoByFilter(Connection connectionPdD, String tipoPlugin, String className, NameValue ... filtri) throws DriverConfigurazioneException, DriverConfigurazioneNotFound{
  212.         
  213.         if(tipoPlugin==null || "".equals(tipoPlugin)) {
  214.             throw new DriverConfigurazioneException("tipo plugin non fornito");
  215.         }
  216.         if(className==null || "".equals(className)) {
  217.             throw new DriverConfigurazioneException("Classname non fornito");
  218.         }
  219.         
  220.         ConfigurazionePdDConnectionResource cr = null;
  221.         try{
  222.             cr = this.getConnection(connectionPdD, "Plugins.getPluginTipo_"+tipoPlugin+"#"+className);
  223.             org.openspcoop2.core.plugins.dao.IServiceManager sm = 
  224.                     (org.openspcoop2.core.plugins.dao.IServiceManager) DAOFactory.getInstance(this.log).
  225.                     getServiceManager(org.openspcoop2.core.plugins.utils.ProjectInfo.getInstance(),
  226.                             cr.connectionDB,this.smp,this.log);
  227.             
  228.             IPluginServiceSearch search =  sm.getPluginServiceSearch();
  229.             
  230.             IExpression expr = search.newExpression();
  231.             expr.equals(Plugin.model().TIPO_PLUGIN, tipoPlugin);
  232.             expr.equals(Plugin.model().CLASS_NAME, className);
  233.             
  234.             Plugin plugin = search.find(expr);
  235.             
  236.             if(filtri!=null && filtri.length>0) {
  237.                 for (int i = 0; i < filtri.length; i++) {
  238.                     NameValue filtro = filtri[i];
  239.                     
  240.                     if(plugin.sizePluginProprietaCompatibilitaList()>0) {
  241.                         for (int j = 0; j < plugin.sizePluginProprietaCompatibilitaList(); j++) {
  242.                             PluginProprietaCompatibilita ppc = plugin.getPluginProprietaCompatibilita(j);
  243.                             if(ppc.getNome().equals(filtro.getName())) {
  244.                                 if(!ppc.getValore().equals(filtro.getValue())) {
  245.                                     
  246.                                     // gestisco caso speciale
  247.                                     boolean isCasoSpecialeQualsiasi = false;
  248.                                     
  249.                                     if(Filtri.FILTRO_RUOLO_NOME.equals(ppc.getNome()) && Filtri.FILTRO_RUOLO_VALORE_ENTRAMBI.equals(ppc.getValore())) {
  250.                                         isCasoSpecialeQualsiasi = true;
  251.                                     }
  252.                                     
  253.                                     if(Filtri.FILTRO_APPLICABILITA_NOME.equals(ppc.getNome())) {
  254.                                         if(Filtri.FILTRO_APPLICABILITA_VALORE_QUALSIASI.equals(ppc.getValore())) {
  255.                                             isCasoSpecialeQualsiasi = true;
  256.                                         }
  257.                                         else if(Filtri.FILTRO_APPLICABILITA_VALORE_FRUIZIONE.equals(filtro.getValue()) && Filtri.FILTRO_APPLICABILITA_VALORE_IMPLEMENTAZIONE_API.equals(ppc.getValore())) {
  258.                                             isCasoSpecialeQualsiasi = true;
  259.                                         } 
  260.                                         else if(Filtri.FILTRO_APPLICABILITA_VALORE_EROGAZIONE.equals(filtro.getValue()) && Filtri.FILTRO_APPLICABILITA_VALORE_IMPLEMENTAZIONE_API.equals(ppc.getValore())) {
  261.                                             isCasoSpecialeQualsiasi = true;
  262.                                         } 
  263.                                     }
  264.                                     
  265.                                     if(!isCasoSpecialeQualsiasi) {                                  
  266.                                         throw new NotFoundException("Filtro '"+ppc.getNome()+"' non soddisfatto (atteso:"+filtro.getValue()+" trovato:"+ppc.getValore()+")");
  267.                                     }
  268.                                 }
  269.                             }
  270.                         }
  271.                     }
  272.                     
  273.                 }
  274.             }
  275.             
  276.             return plugin.getTipo();

  278.         }
  279.         catch(NotFoundException e) {
  280.             String errorMsg = "Plugin (tipologia:"+tipoPlugin+" className:"+className+") non trovato: "+e.getMessage();
  281.             this.log.debug(errorMsg,e);
  282.             throw new DriverConfigurazioneNotFound(errorMsg,e);
  283.         }
  284.         catch(Exception e){
  285.             String errorMsg = "Errore durante la lettura del Plugin (tipologia:"+tipoPlugin+" className:"+className+"): "+e.getMessage();
  286.             this.log.error(errorMsg,e);
  287.             throw new DriverConfigurazioneException(errorMsg,e);
  288.         }
  289.         finally {
  290.             this.releaseConnection(cr);
  291.         }

  293.     }
  294.     
  295.     
  296. }
Created with JaCoCo 0.8.8.202204050719