ServerProperties.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.core.monitor.rs.server.config;

  22. import java.util.Enumeration;
  23. import java.util.Properties;

  25. import org.slf4j.Logger;
  26. import org.openspcoop2.utils.BooleanNullable;
  27. import org.openspcoop2.utils.LoggerWrapperFactory;
  28. import org.openspcoop2.utils.UtilsException;
  29. import org.openspcoop2.utils.UtilsRuntimeException;
  30. import org.openspcoop2.utils.crypt.CryptConfig;
  31. import org.openspcoop2.utils.service.authorization.AuthorizationConfig;
  32. import org.openspcoop2.web.monitor.core.config.ApplicationProperties;
  33. import org.openspcoop2.web.monitor.core.core.Utility;

  35. /**     
  36.  * ServerProperties
  37.  *
  38.  * @author Poli Andrea (poli@link.it)
  39.  * @author $Author$
  40.  * @version $Rev$, $Date$
  41.  */
  42. public class ServerProperties  {

  44.     /** Logger utilizzato per errori eventuali. */
  45.     private Logger log = null;
  46.     
  47.     /** Reader delle proprieta' impostate nel file 'rs-api-monitor.properties' */
  48.     private ServerInstanceProperties reader;
  49.     
  50.     /** Copia Statica */
  51.     private static ServerProperties serverProperties = null;
  52.     
  53.     
  54.     private ServerProperties(String confDir,Logger log) throws UtilsException {

  56.         if(log!=null)
  57.             this.log = log;
  58.         else
  59.             this.log = LoggerWrapperFactory.getLogger(ServerProperties.class);
  60.         
  61.         /* ---- Lettura del cammino del file di configurazione ---- */
  62.         Properties propertiesReader = new Properties();
  63.         try (java.io.InputStream properties = DatasourceProperties.class.getResourceAsStream("/rs-api-monitor.properties")){  
  64.             if(properties==null){
  65.                 throw new UtilsException("File '/rs-api-monitor.properties' not found");
  66.             }
  67.             propertiesReader.load(properties);
  68.         }catch(Exception e) {
  69.             String error="Riscontrato errore durante la lettura del file 'rs-api-monitor.properties': "+e.getMessage();
  70.             this.log.error(error);
  71.             throw new UtilsException("RS Api MonitorProperties initialize error: "+e.getMessage());
  72.         }

  74.         this.reader = new ServerInstanceProperties(propertiesReader, this.log, confDir);
  75.         
  76.         this.log.info("Inizializzazione ApplicationProperties in corso...");
  77.         try{
  78.             ApplicationProperties.initialize(log, "/rs-api-monitor.properties", ConstantsEnv.OPENSPCOOP2_RS_API_MONITOR_PROPERTIES, ConstantsEnv.OPENSPCOOP2_RS_API_MONITOR_LOCAL_PATH);
  79.         }catch(Exception e){
  80.             throw new UtilsRuntimeException(e.getMessage(),e);
  81.         }
  82.         this.log.info("Inizializzazione ApplicationProperties effettuata con successo");
  83.     }


  86.     /**
  87.      * Il Metodo si occupa di inizializzare il propertiesReader 
  88.      *
  89.      * 
  90.      */
  91.     public static boolean initialize(String confDir,Logger log){

  93.         try {
  94.             ServerProperties.serverProperties = new ServerProperties(confDir,log);  
  95.             return true;
  96.         }
  97.         catch(Exception e) {
  98.             log.error("Errore durante l'inizializzazione del ServerProperties: "+e.getMessage(),e);        
  99.             return false;
  100.         }
  101.     }
  102.     
  103.     /**
  104.      * Ritorna l'istanza di questa classe
  105.      *
  106.      * @return Istanza di Properties
  107.      * 
  108.      */
  109.     public static ServerProperties getInstance() throws UtilsException{
  110.         if(ServerProperties.serverProperties==null){
  111.             // spotbugs warning 'SING_SINGLETON_GETTER_NOT_SYNCHRONIZED': l'istanza viene creata allo startup
  112.             synchronized (ServerProperties.class) {
  113.                 throw new UtilsException("ServerProperties non inizializzato");
  114.             }
  115.         }
  116.         return ServerProperties.serverProperties;
  117.     }
  118.     
  119.     public static void updateLocalImplementation(Properties prop){
  120.         ServerProperties.serverProperties.reader.setLocalObjectImplementation(prop);
  121.     }








  130.     /* ********  M E T O D I  ******** */

  132.     private boolean parse(BooleanNullable b, boolean defaultValue) {
  133.         return (b!=null && b.getValue()!=null) ? b.getValue() : defaultValue;
  134.     }
  135.     
  136.     public String readProperty(boolean required,String property) throws UtilsException{
  137.         String tmp = this.reader.getValueConvertEnvProperties(property);
  138.         if(tmp==null){
  139.             if(required){
  140.                 throw new UtilsException("Property ["+property+"] not found");
  141.             }
  142.             else{
  143.                 return null;
  144.             }
  145.         }else{
  146.             return tmp.trim();
  147.         }
  148.     }
  149.     
  150.     private BooleanNullable readBooleanProperty(boolean required,String property) throws UtilsException{
  151.         String tmp = this.readProperty(required, property);
  152.         if(tmp==null && !required) {
  153.             return BooleanNullable.NULL(); // se e' required viene sollevata una eccezione dal metodo readProperty
  154.         }
  155.         if(!"true".equalsIgnoreCase(tmp) && !"false".equalsIgnoreCase(tmp)){
  156.             throw new UtilsException("Property ["+property+"] with uncorrect value ["+tmp+"] (true/value expected)");
  157.         }
  158.         return Boolean.parseBoolean(tmp) ? BooleanNullable.TRUE() : BooleanNullable.FALSE();
  159.     }
  160.     
  161.     public Properties getProperties() throws UtilsException{
  162.         Properties p = new Properties();
  163.         Enumeration<?> names = this.reader.propertyNames();
  164.         while (names.hasMoreElements()) {
  165.             String name = (String) names.nextElement();
  166.             p.put(name, this.reader.getValueConvertEnvProperties(name));
  167.         }
  168.         return p;
  169.     }
  170.     
  171.     private AuthorizationConfig authConfig = null;
  172.     private synchronized void initAuthorizationConfig() throws UtilsException {
  173.         if(this.authConfig==null) {
  174.             this.authConfig = new AuthorizationConfig(getProperties());
  175.         }
  176.     }
  177.     public AuthorizationConfig getAuthorizationConfig() throws UtilsException {
  178.         if(this.authConfig==null) {
  179.             this.initAuthorizationConfig();
  180.         }
  181.         return this.authConfig;
  182.     }

  184.     
  185.     public String getConfDirectory() throws UtilsException {
  186.         return this.readProperty(false, "confDirectory");
  187.     }
  188.     public String getProtocolloDefault() throws UtilsException {
  189.         return this.readProperty(true, "protocolloDefault");
  190.     }
  191.     
  192.     public boolean isJdbcCloseConnectionCheckIsClosed() throws UtilsException{
  193.         BooleanNullable b = this.readBooleanProperty(true, "jdbc.closeConnection.checkIsClosed");
  194.         return this.parse(b, true);
  195.     }
  196.     public boolean isJdbcCloseConnectionCheckAutocommit() throws UtilsException{
  197.         BooleanNullable b = this.readBooleanProperty(true, "jdbc.closeConnection.checkAutocommit");
  198.         return this.parse(b, true);
  199.     }
  200.     
  201.     public boolean isFindall404() throws UtilsException {
  202.         return Boolean.parseBoolean(this.readProperty(true, "findall_404"));
  203.     }
  204.     
  205.     
  206.     public boolean useSoggettoDefault() throws UtilsException {
  207.         if(Utility.isMultitenantAbilitato()) {
  208.             return Boolean.parseBoolean(this.readProperty(true, "multitenant.forzaSoggettoDefault"));
  209.         }
  210.         else {
  211.             return true; // in caso di multitenant disabilitato, il soggetto di default viene sempre impostato
  212.         }
  213.     }
  214.             
  215.     public String getSoggettoDefaultIfEnabled(String protocollo) throws UtilsException {
  216.         if(this.useSoggettoDefault()) {
  217.             String p = this.readProperty(false, protocollo+".soggetto");
  218.             if(p!=null) {
  219.                 return p;
  220.             }
  221.             return this.readProperty(true, "soggetto");
  222.         }
  223.         else {
  224.             throw new UtilsException("Utilizzo del soggetto di default non abilitato");
  225.         }
  226.     }


  229.     public org.openspcoop2.utils.service.context.ContextConfig getContextConfig() throws UtilsException {
  230.         org.openspcoop2.utils.service.context.ContextConfig config = new org.openspcoop2.utils.service.context.ContextConfig();
  231.         config.setClusterId(this.readProperty(false, "clusterId"));
  232.         config.setDump(Boolean.parseBoolean(this.readProperty(true, "dump")));
  233.         config.setEmitTransaction(Boolean.parseBoolean(this.readProperty(true, "transaction")));
  234.         config.setServiceType(this.readProperty(false, "service.type"));
  235.         config.setServiceName(this.readProperty(false, "service.name"));
  236.         config.setServiceVersion(Integer.parseInt(this.readProperty(false, "service.version")));
  237.         return config;
  238.     }
  239.     
  240.     public String getUtenzePassword() throws UtilsException{
  241.         return this.readProperty(true, "utenti.password");
  242.     }
  243.     private static CryptConfig utenzeCryptConfig = null;
  244.     private static synchronized void initUtenzeCryptConfig(String p) throws UtilsException {
  245.         if(utenzeCryptConfig==null) {
  246.             utenzeCryptConfig = new CryptConfig(p);
  247.         }
  248.     }
  249.     public CryptConfig getUtenzeCryptConfig() throws UtilsException {
  250.         if(utenzeCryptConfig==null) {
  251.             initUtenzeCryptConfig(getUtenzePassword());
  252.         }
  253.         return utenzeCryptConfig;
  254.     }
  255.     
  256.     
  257.     public int getTransazioniDettaglioVisualizzazioneMessaggiThreshold() throws NumberFormatException, UtilsException {
  258.         return Integer.valueOf(this.readProperty(true, "transazioni.dettaglio.visualizzazioneMessaggi.threshold"));
  259.     }
  260.     
  261.     
  262.     
  263.     public boolean isSecurityLoadBouncyCastleProvider() throws UtilsException{
  264.         BooleanNullable b = this.readBooleanProperty(false, "security.addBouncyCastleProvider");
  265.         return parse(b, false);
  266.     }
  267.     
  268.     
  269.     public String getEnvMapConfig() throws UtilsException{
  270.         return this.readProperty(false, "env.map.config");
  271.     }
  272.     public boolean isEnvMapConfigRequired() throws UtilsException{
  273.         BooleanNullable b = this.readBooleanProperty(false, "env.map.required");
  274.         return this.parse(b, false);
  275.     }
  276.     
  277.     
  278.     public String getHSMConfigurazione() throws UtilsException {
  279.         return this.readProperty(false, "hsm.config");
  280.     }
  281.     public boolean isHSMRequired() throws UtilsException {
  282.         BooleanNullable b = this.readBooleanProperty(false, "hsm.required");
  283.         return parse(b, false);
  284.     }
  285.     public boolean isHSMKeyPasswordConfigurable() throws UtilsException{
  286.         BooleanNullable b = this.readBooleanProperty(false, "hsm.keyPassword");
  287.         return this.parse(b, false);
  288.     }
  289.     
  290.     
  291.     
  292.     public String getBYOKConfigurazione() throws UtilsException{
  293.         return this.readProperty(false, "byok.config");
  294.     }
  295.     public boolean isBYOKRequired() throws UtilsException{
  296.         BooleanNullable b = this.readBooleanProperty(false, "byok.required");
  297.         return parse(b, false);
  298.     }
  299.     public String getBYOKEnvSecretsConfig() throws UtilsException{
  300.         return this.readProperty(false, "byok.env.secrets.config");
  301.     }
  302.     public boolean isBYOKEnvSecretsConfigRequired() throws UtilsException{
  303.         BooleanNullable b = this.readBooleanProperty(false, "byok.env.secrets.required");
  304.         return this.parse(b, false);
  305.     }
  306.     
  307.     
  308.     public String getConfigurazioneNodiRuntime() throws UtilsException{
  309.         return this.readProperty(false, "configurazioni.configurazioneNodiRun");
  310.     }
  311. }
Created with JaCoCo 0.8.8.202204050719