GestoreCacheCleaner.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.pdd.core.cache;

  22. import java.sql.Connection;
  23. import java.util.ArrayList;
  24. import java.util.List;

  26. import org.openspcoop2.core.config.GenericProperties;
  27. import org.openspcoop2.core.config.PortaApplicativa;
  28. import org.openspcoop2.core.config.PortaApplicativaServizioApplicativo;
  29. import org.openspcoop2.core.config.ServizioApplicativo;
  30. import org.openspcoop2.core.config.constants.CostantiConfigurazione;
  31. import org.openspcoop2.core.config.driver.IDriverConfigurazioneGet;
  32. import org.openspcoop2.core.config.driver.db.DriverConfigurazioneDB;
  33. import org.openspcoop2.core.id.IDAccordo;
  34. import org.openspcoop2.core.id.IDAccordoCooperazione;
  35. import org.openspcoop2.core.id.IDConnettore;
  36. import org.openspcoop2.core.id.IDGenericProperties;
  37. import org.openspcoop2.core.id.IDPortaApplicativa;
  38. import org.openspcoop2.core.id.IDPortaDelegata;
  39. import org.openspcoop2.core.id.IDRuolo;
  40. import org.openspcoop2.core.id.IDScope;
  41. import org.openspcoop2.core.id.IDServizio;
  42. import org.openspcoop2.core.id.IDServizioApplicativo;
  43. import org.openspcoop2.core.id.IDSoggetto;
  44. import org.openspcoop2.core.mapping.DBMappingUtils;
  45. import org.openspcoop2.core.registry.AccordoCooperazione;
  46. import org.openspcoop2.core.registry.AccordoServizioParteSpecifica;
  47. import org.openspcoop2.core.registry.Fruitore;
  48. import org.openspcoop2.core.registry.Ruolo;
  49. import org.openspcoop2.core.registry.Scope;
  50. import org.openspcoop2.core.registry.Soggetto;
  51. import org.openspcoop2.core.registry.beans.AccordoServizioParteComuneSintetico;
  52. import org.openspcoop2.core.registry.driver.IDAccordoCooperazioneFactory;
  53. import org.openspcoop2.core.registry.driver.IDAccordoFactory;
  54. import org.openspcoop2.core.registry.driver.IDServizioFactory;
  55. import org.openspcoop2.core.registry.driver.IDriverRegistroServiziGet;
  56. import org.openspcoop2.core.registry.driver.db.DriverRegistroServiziDB;
  57. import org.openspcoop2.pdd.config.ConfigurazionePdDReader;
  58. import org.openspcoop2.pdd.core.GestoreRichieste;
  59. import org.openspcoop2.pdd.core.autenticazione.GestoreAutenticazione;
  60. import org.openspcoop2.pdd.core.autorizzazione.GestoreAutorizzazione;
  61. import org.openspcoop2.pdd.core.behaviour.built_in.load_balance.GestoreLoadBalancerCaching;
  62. import org.openspcoop2.pdd.core.token.GestoreToken;
  63. import org.openspcoop2.protocol.registry.RegistroServiziReader;

  65. /**
  66.  * GestoreCacheCleaner
  67.  *
  68.  * @author Andrea Poli (apoli@link.it)
  69.  * @author $Author$
  70.  * @version $Rev$, $Date$
  71.  */
  72. public class GestoreCacheCleaner {
  73.     
  74.     private GestoreCacheCleaner() {}

  76.     private static List<ICacheCleaner> listCacheCleaner = new ArrayList<>();
  77.     private static DriverRegistroServiziDB driverRegistroDB = null;
  78.     private static DriverConfigurazioneDB driverConfigDB = null;
  79.     
  80.     public static void initialize() throws Exception {
  81.         
  82.         if(GestoreRichieste.isCacheAbilitata()) {
  83.             listCacheCleaner.add(new GestoreRichiesteCacheCleaner());
  84.         }
  85.         if(RegistroServiziReader.isCacheAbilitata()) {
  86.             listCacheCleaner.add(new RegistroServiziCacheCleaner());
  87.         }
  88.         if(ConfigurazionePdDReader.isCacheAbilitata()) {
  89.             listCacheCleaner.add(new ConfigurazioneCacheCleaner());
  90.         }
  91.         if(GestoreAutenticazione.isCacheAbilitata()) {
  92.             listCacheCleaner.add(new AutenticazioneCacheCleaner());
  93.         }
  94.         if(GestoreAutorizzazione.isCacheAbilitata()) {
  95.             listCacheCleaner.add(new AutorizzazioneCacheCleaner());
  96.         }
  97.         if(GestoreToken.isGestioneTokenCacheAbilitata()) {
  98.             listCacheCleaner.add(new GestoreTokenCacheCleaner());
  99.         }
  100.         if(GestoreToken.isAttributeAuthorityCacheAbilitata()) {
  101.             listCacheCleaner.add(new AttributeAuthorityCacheCleaner());
  102.         }
  103.         if(GestoreLoadBalancerCaching.isCacheAbilitata()) {
  104.             listCacheCleaner.add(new GestoreLoadBalancerCacheCleaner());
  105.         }
  106.         
  107.         for (IDriverRegistroServiziGet driver : RegistroServiziReader.getDriverRegistroServizi().values()) {
  108.             if(driver instanceof DriverRegistroServiziDB) {
  109.                 driverRegistroDB = (DriverRegistroServiziDB) driver;
  110.                 break;
  111.             }
  112.         }
  113.         
  114.         IDriverConfigurazioneGet driver = ConfigurazionePdDReader.getDriverConfigurazionePdD();
  115.         if(driver instanceof DriverConfigurazioneDB) {
  116.             driverConfigDB = (DriverConfigurazioneDB) driver;
  117.         }
  118.         
  119.     }
  120.     
  121.     public static void removeAccordoCooperazione(long id) throws Exception {
  122.         if(!listCacheCleaner.isEmpty() && driverRegistroDB!=null) {
  123.             AccordoCooperazione ac = driverRegistroDB.getAccordoCooperazione(id);
  124.             if(ac!=null) {
  125.                 IDAccordoCooperazione idAccordoCooperazione = IDAccordoCooperazioneFactory.getInstance().getIDAccordoFromAccordo(ac);
  126.                 for (ICacheCleaner iCacheCleaner : listCacheCleaner) {
  127.                     iCacheCleaner.removeAccordoCooperazione(idAccordoCooperazione);
  128.                 }
  129.             }
  130.         }
  131.     }
  132.     
  133.     public static void removeAccordoServizioParteComune(long id) throws Exception {
  134.         if(!listCacheCleaner.isEmpty() && driverRegistroDB!=null) {
  135.             AccordoServizioParteComuneSintetico as = driverRegistroDB.getAccordoServizioParteComuneSintetico(id);
  136.             if(as!=null) {
  137.                 IDAccordo idAccordo = IDAccordoFactory.getInstance().getIDAccordoFromAccordo(as);
  138.                 for (ICacheCleaner iCacheCleaner : listCacheCleaner) {
  139.                     iCacheCleaner.removeApi(idAccordo);
  140.                 }
  141.             }
  142.         }
  143.     }
  144.     
  145.     public static void removeErogazione(long id) throws Exception {
  146.         if(!listCacheCleaner.isEmpty() && driverRegistroDB!=null && driverConfigDB!=null) {
  147.             AccordoServizioParteSpecifica as = driverRegistroDB.getAccordoServizioParteSpecifica(id, false);
  148.             if(as!=null) {
  149.                 IDServizio idServizio = IDServizioFactory.getInstance().getIDServizioFromAccordo(as);
  150.                 List<IDPortaApplicativa> idPorteApplicative = null;
  151.                 List<IDConnettore> idConnettori = null;
  152.                 List<IDServizioApplicativo> idServiziApplicativiErogatori = null;
  153.                 
  154.                 Connection con = null;
  155.                 try {
  156.                     con = driverConfigDB.getConnection("getIDPorteApplicativeAssociate");
  157.                     idPorteApplicative = DBMappingUtils.getIDPorteApplicativeAssociate(idServizio, con, driverConfigDB.getTipoDB());
  158.                 }finally {
  159.                     driverConfigDB.releaseConnection(con);
  160.                 }

  162.                 if(idPorteApplicative!=null && !idPorteApplicative.isEmpty()) {
  163.                     for (IDPortaApplicativa idPortaApplicativa : idPorteApplicative) {
  164.                         PortaApplicativa pa = driverConfigDB.getPortaApplicativa(idPortaApplicativa);
  165.                         
  166.                         if(idServiziApplicativiErogatori==null) {
  167.                             idServiziApplicativiErogatori = new ArrayList<>();
  168.                         }
  169.                         for (PortaApplicativaServizioApplicativo paSa : pa.getServizioApplicativoList()) {
  170.                             IDServizioApplicativo idSA = new IDServizioApplicativo();
  171.                             idSA.setIdSoggettoProprietario(idServizio.getSoggettoErogatore());
  172.                             idSA.setNome(paSa.getNome());
  173.                             idServiziApplicativiErogatori.add(idSA);
  174.                         }
  175.                         
  176.                         if(pa.getBehaviour()!=null && pa.sizeServizioApplicativoList()>0) {
  177.                             if(idConnettori==null) {
  178.                                 idConnettori = new ArrayList<>();
  179.                             }
  180.                             for (PortaApplicativaServizioApplicativo paSa : pa.getServizioApplicativoList()) {
  181.                                 IDConnettore idConnettore = new IDConnettore();
  182.                                 idConnettore.setIdSoggettoProprietario(idServizio.getSoggettoErogatore());
  183.                                 idConnettore.setNome(paSa.getNome());
  184.                                 idConnettore.setNomeConnettore(paSa.getDatiConnettore()!=null && paSa.getDatiConnettore().getNome()!=null ? 
  185.                                         paSa.getDatiConnettore().getNome() : CostantiConfigurazione.NOME_CONNETTORE_DEFAULT);
  186.                                 idConnettori.add(idConnettore);
  187.                             }
  188.                         }
  189.                     }
  190.                 }
  191.                 
  192.                 for (ICacheCleaner iCacheCleaner : listCacheCleaner) {
  193.                     iCacheCleaner.removeErogazione(idServizio);
  194.                     if(idPorteApplicative!=null && !idPorteApplicative.isEmpty()) {
  195.                         for (IDPortaApplicativa idPortaApplicativa : idPorteApplicative) {
  196.                             iCacheCleaner.removePortaApplicativa(idPortaApplicativa);
  197.                         }
  198.                     }
  199.                     if(idServiziApplicativiErogatori!=null && !idServiziApplicativiErogatori.isEmpty()) {
  200.                         for (IDServizioApplicativo idSA : idServiziApplicativiErogatori) {
  201.                             iCacheCleaner.removeApplicativo(idSA);
  202.                         }
  203.                     }
  204.                     if(idConnettori!=null && !idConnettori.isEmpty()) {
  205.                         for (IDConnettore idConnettore : idConnettori) {
  206.                             iCacheCleaner.removeConnettore(idConnettore);
  207.                         }
  208.                     }
  209.                 }
  210.             }
  211.         }
  212.     }
  213.     
  214.     public static void removeFruizione(long id) throws Exception {
  215.         if(!listCacheCleaner.isEmpty() && driverRegistroDB!=null && driverConfigDB!=null) {
  216.             Fruitore fruitore = driverRegistroDB.getServizioFruitore(id);
  217.             if(fruitore!=null) {
  218.                 AccordoServizioParteSpecifica as = driverRegistroDB.getAccordoServizioParteSpecifica(fruitore.getIdServizio(), false);
  219.                 IDSoggetto idFruitore = driverRegistroDB.getIdSoggetto(fruitore.getIdSoggetto());
  220.                 if(as!=null) {
  221.                     IDServizio idServizio = IDServizioFactory.getInstance().getIDServizioFromAccordo(as);
  222.                     List<IDPortaDelegata> idPorteDelegate = null;
  223.                     
  224.                     Connection con = null;
  225.                     try {
  226.                         con = driverConfigDB.getConnection("getIDPorteApplicativeAssociate");
  227.                         idPorteDelegate = DBMappingUtils.getIDPorteDelegateAssociate(idServizio, idFruitore, con, driverConfigDB.getTipoDB());
  228.                     }finally {
  229.                         driverConfigDB.releaseConnection(con);
  230.                     }
  231.                     
  232.                     for (ICacheCleaner iCacheCleaner : listCacheCleaner) {
  233.                         iCacheCleaner.removeFruizione(idFruitore, idServizio);
  234.                         if(idPorteDelegate!=null && !idPorteDelegate.isEmpty()) {
  235.                             for (IDPortaDelegata idPortaDelegata : idPorteDelegate) {
  236.                                 iCacheCleaner.removePortaDelegata(idPortaDelegata);
  237.                             }
  238.                         }
  239.                     }
  240.                 }
  241.             }
  242.         }
  243.     }
  244.     
  245.     public static void removeSoggetto(long id) throws Exception {
  246.         if(!listCacheCleaner.isEmpty() && driverRegistroDB!=null) {
  247.             Soggetto soggetto = driverRegistroDB.getSoggetto(id);
  248.             if(soggetto!=null) {
  249.                 
  250.                 IDSoggetto idSoggetto = new IDSoggetto(soggetto.getTipo(), soggetto.getNome());
  251.                 String portaDominio = soggetto.getPortaDominio();
  252.                 
  253.                 for (ICacheCleaner iCacheCleaner : listCacheCleaner) {
  254.                     iCacheCleaner.removeSoggetto(idSoggetto);
  255.                     if(portaDominio!=null) {
  256.                         iCacheCleaner.removePdd(portaDominio);
  257.                     }
  258.                 }
  259.             }
  260.         }
  261.     }
  262.     
  263.     public static void removeApplicativo(long id) throws Exception {
  264.         if(!listCacheCleaner.isEmpty() && driverConfigDB !=null) {
  265.             ServizioApplicativo sa = driverConfigDB.getServizioApplicativo(id);
  266.             if(sa!=null) {
  267.                 
  268.                 IDSoggetto idSoggetto = new IDSoggetto(sa.getTipoSoggettoProprietario(), sa.getNomeSoggettoProprietario());
  269.                 IDServizioApplicativo idSA = new IDServizioApplicativo();
  270.                 idSA.setIdSoggettoProprietario(idSoggetto);
  271.                 idSA.setNome(sa.getNome());

  273.                 for (ICacheCleaner iCacheCleaner : listCacheCleaner) {
  274.                     iCacheCleaner.removeApplicativo(idSA);
  275.                 }
  276.             }
  277.         }
  278.     }
  279.     
  280.     public static void removeRuolo(long id) throws Exception {
  281.         if(!listCacheCleaner.isEmpty() && driverRegistroDB!=null) {
  282.             Ruolo ruolo = driverRegistroDB.getRuolo(id);
  283.             if(ruolo!=null) {
  284.                 
  285.                 IDRuolo idRuolo = new IDRuolo(ruolo.getNome());
  286.                 
  287.                 for (ICacheCleaner iCacheCleaner : listCacheCleaner) {
  288.                     iCacheCleaner.removeRuolo(idRuolo);
  289.                 }
  290.             }
  291.         }
  292.     }
  293.     
  294.     public static void removeScope(long id) throws Exception {
  295.         if(!listCacheCleaner.isEmpty() && driverRegistroDB!=null) {
  296.             Scope scope = driverRegistroDB.getScope(id);
  297.             if(scope!=null) {
  298.                 
  299.                 IDScope idScope = new IDScope(scope.getNome());
  300.                 
  301.                 for (ICacheCleaner iCacheCleaner : listCacheCleaner) {
  302.                     iCacheCleaner.removeScope(idScope);
  303.                 }
  304.             }
  305.         }
  306.     }
  307.     
  308.     public static void removeGenericProperties(long id) throws Exception {
  309.         if(!listCacheCleaner.isEmpty() && driverConfigDB !=null) {
  310.             GenericProperties gp = driverConfigDB.getGenericProperties(id);
  311.             if(gp!=null) {
  312.                 
  313.                 IDGenericProperties idGP = new IDGenericProperties();
  314.                 idGP.setTipologia(gp.getTipologia());
  315.                 idGP.setNome(gp.getNome());

  317.                 for (ICacheCleaner iCacheCleaner : listCacheCleaner) {
  318.                     iCacheCleaner.removeGenericProperties(idGP);
  319.                 }
  320.             }
  321.         }
  322.     }
  323. }
Created with JaCoCo 0.8.8.202204050719