1 files changed, 185 insertions, 0 deletions
diff --git a/eaaf_core/src/main/java/at/gv/egiz/eaaf/core/impl/idp/conf/AbstractConfigurationImpl.java b/eaaf_core/src/main/java/at/gv/egiz/eaaf/core/impl/idp/conf/AbstractConfigurationImpl.java
new file mode 100644
index 00000000..2b868b16
--- /dev/null
+++ b/eaaf_core/src/main/java/at/gv/egiz/eaaf/core/impl/idp/conf/AbstractConfigurationImpl.java
@@ -0,0 +1,185 @@
+/*******************************************************************************
+ *******************************************************************************/
+package at.gv.egiz.eaaf.core.impl.idp.conf;
+
+import java.io.File;
+import java.io.FileInputStream;
+import java.io.IOException;
+import java.io.InputStream;
+import java.net.URI;
+import java.net.URISyntaxException;
+import java.util.Map;
+import java.util.Properties;
+
+import org.apache.commons.lang3.StringUtils;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+import at.gv.egiz.eaaf.core.api.idp.IConfiguration;
+import at.gv.egiz.eaaf.core.exceptions.EAAFConfigurationException;
+import at.gv.egiz.eaaf.core.impl.utils.KeyValueUtils;
+
+public abstract class AbstractConfigurationImpl implements IConfiguration {
+	private static final Logger log = LoggerFactory.getLogger(AbstractConfigurationImpl.class);
+	
+	private static final String URI_SCHEME_CLASSPATH = "classpath";
+	private static final String URI_SCHEME_FILESYSTEM = "file";
+	
+	private final URI internalConfigPath;
+	private final URI configRootDirectory;
+	private final Properties properties;
+	
+	public AbstractConfigurationImpl(final String configPath) throws EAAFConfigurationException {
+		InputStream is = null;
+		try {
+			log.debug("Starting EAAFCore initialization process .... ");
+			
+			if (StringUtils.isEmpty(configPath)) {
+				log.debug("Primary configuration is empty. Search for backup configuration .... ");
+				internalConfigPath = new URI(getBackupConfigPath());
+							
+			} else
+				internalConfigPath = new URI(configPath);
+									
+			log.info("Load EAAFCore configuration from " + internalConfigPath);
+			
+			
+			//extract configuration root directory
+			//TODO: check if it works with classpath
+			File propertiesFile = new File(internalConfigPath);
+			String configDir = propertiesFile.getParent();
+			configRootDirectory = new File(configDir).toURI();			
+			log.debug("Set EAAFCore configuration root directory to " + configRootDirectory.toString());
+			
+			
+			//get input stream from configuration path 			
+			if (internalConfigPath.getScheme().equals(URI_SCHEME_FILESYSTEM)) {
+				log.trace("Load config from filesystem");
+				is = new FileInputStream(propertiesFile);
+				
+			} else if (internalConfigPath.getScheme().equals(URI_SCHEME_CLASSPATH)) {
+				log.trace("Load config from classpath");
+				is = this.getClass().getResourceAsStream(internalConfigPath.toString());
+				
+			} else {
+				log.error("Can not load EAAFCore configuration. Unsupported prefix! (Only 'file:' and 'classpath:')  ");
+				throw new EAAFConfigurationException("Can not load EAAFCore configuration. Unsupported prefix");
+				
+			}
+			
+			if (is == null) {
+				log.error("Can NOT load EAAFCore configuration from file " +  internalConfigPath.toString());
+				throw new EAAFConfigurationException("Can NOT load EAAFCore configuration from file " + internalConfigPath.toString());
+				
+			}
+			
+			
+			//load EAAF core configuration into properties object
+			properties = new Properties();
+			properties.load(is);
+			
+			log.info("EAAFCore configuration loaded");
+			
+			
+		} catch (URISyntaxException | IOException e) {
+			log.error("Can not parse configuration path " + configPath + " or " + getBackupConfigPath());
+			throw new EAAFConfigurationException("Can not parse configuration path", e);
+			
+		} finally {
+			if (is != null) {
+				try {
+					is.close();
+					
+				} catch (IOException e) {
+					log.warn("Can not close inputstream from configuration loader!");
+					
+				}
+			}
+		}
+		
+	}
+	
+	@Override
+	public String getBasicConfiguration(String key) {
+		if (StringUtils.isNotEmpty(key)) {
+			String value = properties.getProperty(addPrefixToKey(key));
+			if (value != null)
+				return value.trim();
+		}
+		
+		return null;
+	}
+
+	@Override
+	public String getBasicConfiguration(String key, String defaultValue) {
+		if (StringUtils.isNotEmpty(key)) {
+			String value = properties.getProperty(addPrefixToKey(key), defaultValue);
+			if (value != null)
+				return value.trim();
+		}
+		
+		return defaultValue;
+	}
+
+	@Override
+	public Map<String, String> getBasicMOAIDConfigurationWithPrefix(String prefix) {
+		return KeyValueUtils.getSubSetWithPrefix(KeyValueUtils.convertPropertiesToMap(properties), addPrefixToKey(prefix));
+		
+	}
+
+	@Override
+	public boolean getBasicMOAIDConfigurationBoolean(String key, boolean defaultValue) {
+		String value = getBasicConfiguration(key);		
+		if (StringUtils.isNotEmpty(value))
+			return Boolean.valueOf(value.trim());
+						
+		return defaultValue;
+		
+	}
+	
+	@Override
+	public Properties getFullConfigurationProperties() {
+		return properties;
+		
+	}
+
+	@Override
+	public URI getConfigurationRootDirectory() {
+		return configRootDirectory;
+		
+	}
+	
+	@Override
+	public URI getConfigurationFilePath() {
+		return internalConfigPath;
+		
+	}
+	
+	/**
+	 * Get the path to backup configuration
+	 * 
+	 * @return A filepath file: or a classpath classpath:
+	 */
+	abstract protected String getBackupConfigPath();
+	
+	/**
+	 * Get a specific configuration-key prefix for this software implementation
+	 * 
+	 * @return
+	 */
+	abstract public String getApplicationSpecificKeyPrefix();
+
+	
+	private String addPrefixToKey(String key) {
+		if (StringUtils.isNotEmpty(getApplicationSpecificKeyPrefix())) {
+			if (getApplicationSpecificKeyPrefix().endsWith(KeyValueUtils.KEY_DELIMITER))
+				return getApplicationSpecificKeyPrefix() + key;
+			else
+				return getApplicationSpecificKeyPrefix() + KeyValueUtils.KEY_DELIMITER + key;
+			
+		}
+		
+		return key;
+		
+	}
+}