-package org.openecomp.config.impl;
+package org.onap.config.impl;
-import static org.openecomp.config.ConfigurationUtils.getConfigurationRepositoryKey;
-import static org.openecomp.config.ConfigurationUtils.getProperty;
-import static org.openecomp.config.ConfigurationUtils.isExternalLookup;
-import static org.openecomp.config.ConfigurationUtils.isWrapperClass;
-import static org.openecomp.config.ConfigurationUtils.isZeroLengthArray;
-
-import static org.openecomp.config.Constants.DB_NAMESPACE;
-import static org.openecomp.config.Constants.DEFAULT_NAMESPACE;
-import static org.openecomp.config.Constants.DEFAULT_TENANT;
-import static org.openecomp.config.Constants.KEY_ELEMENTS_DELEMETER;
+import static org.onap.config.ConfigurationUtils.getConfigurationRepositoryKey;
import org.apache.commons.configuration2.Configuration;
import org.apache.commons.configuration2.DatabaseConfiguration;
-import org.openecomp.config.ConfigurationUtils;
-import org.openecomp.config.Constants;
-import org.openecomp.config.NonConfigResource;
-import org.openecomp.config.api.Config;
-import org.openecomp.config.api.ConfigurationChangeListener;
-import org.openecomp.config.api.Hint;
+import org.onap.config.ConfigurationUtils;
+import org.onap.config.Constants;
+import org.onap.config.NonConfigResource;
+import org.onap.config.api.Config;
+import org.onap.config.api.ConfigurationChangeListener;
+import org.onap.config.api.Hint;
import java.io.File;
import java.lang.reflect.Constructor;
/**
* The type Configuration.
*/
-public class ConfigurationImpl implements org.openecomp.config.api.Configuration {
+public class ConfigurationImpl implements org.onap.config.api.Configuration {
private static ThreadLocal<String> tenant = new ThreadLocal<String>() {
protected String initialValue() {
Predicate<URL> predicate = ConfigurationUtils::isConfig;
for (URL url : classpathResources) {
if (predicate.test(url)) {
- String moduleName = getConfigurationRepositoryKey(url);
+ String moduleName = ConfigurationUtils.getConfigurationRepositoryKey(url);
AggregateConfiguration moduleConfig = moduleConfigStore.get(moduleName);
if (moduleConfig == null) {
moduleConfig = new AggregateConfiguration();
Predicate<File> filePredicate = ConfigurationUtils::isConfig;
for (File file : filesystemResources) {
if (filePredicate.test(file)) {
- String moduleName = getConfigurationRepositoryKey(file);
+ String moduleName = ConfigurationUtils.getConfigurationRepositoryKey(file);
AggregateConfiguration moduleConfig = moduleConfigStore.get(moduleName);
if (moduleConfig == null) {
moduleConfig = new AggregateConfiguration();
String moduleName = ConfigurationUtils.getNamespace(file);
for (File tenanatFileRoot : tenantsRoot) {
if (file.getAbsolutePath().startsWith(tenanatFileRoot.getAbsolutePath())) {
- moduleName = getConfigurationRepositoryKey(
+ moduleName = ConfigurationUtils.getConfigurationRepositoryKey(
(tenanatFileRoot.getName().toUpperCase() + Constants.TENANT_NAMESPACE_SAPERATOR
+ moduleName).split(Constants.TENANT_NAMESPACE_SAPERATOR));
}
for (File file : filesystemResources) {
if (filePredicate.test(file)) {
ConfigurationRepository.lookup().populateOverrideConfigurtaion(
- getConfigurationRepositoryKey(ConfigurationUtils.getNamespace(file)
+ ConfigurationUtils.getConfigurationRepositoryKey(ConfigurationUtils.getNamespace(file)
.split(Constants.TENANT_NAMESPACE_SAPERATOR)), file);
}
}
clazz.isPrimitive() ? getWrapperClass(clazz) : clazz,
hints == null || hints.length == 0 ? new Hint[]{Hint.EXTERNAL_LOOKUP, Hint.NODE_SPECIFIC}
: hints);
- if ((returnValue == null || isZeroLengthArray(clazz, returnValue))
+ if ((returnValue == null || ConfigurationUtils.isZeroLengthArray(clazz, returnValue))
&& !Constants.DEFAULT_TENANT.equals(tenant)) {
returnValue = (T) getInternal(Constants.DEFAULT_TENANT, namespace, key,
clazz.isPrimitive() ? getWrapperClass(clazz) : clazz,
hints == null || hints.length == 0 ? new Hint[]{Hint.EXTERNAL_LOOKUP, Hint.NODE_SPECIFIC}
: hints);
}
- if ((returnValue == null || isZeroLengthArray(clazz, returnValue))
+ if ((returnValue == null || ConfigurationUtils.isZeroLengthArray(clazz, returnValue))
&& !Constants.DEFAULT_NAMESPACE.equals(namespace)) {
returnValue = (T) getInternal(tenant, Constants.DEFAULT_NAMESPACE, key,
clazz.isPrimitive() ? getWrapperClass(clazz) : clazz,
hints == null || hints.length == 0 ? new Hint[]{Hint.EXTERNAL_LOOKUP, Hint.NODE_SPECIFIC}
: hints);
}
- if ((returnValue == null ||isZeroLengthArray(clazz, returnValue))
+ if ((returnValue == null || ConfigurationUtils.isZeroLengthArray(clazz, returnValue))
&& !Constants.DEFAULT_NAMESPACE.equals(namespace)
&& !Constants.DEFAULT_TENANT.equals(tenant)) {
returnValue = (T) getInternal(Constants.DEFAULT_TENANT, Constants.DEFAULT_NAMESPACE, key,
clazz = getWrapperClass(clazz);
}
try {
- if (isWrapperClass(clazz) || clazz.isPrimitive()) {
+ if (ConfigurationUtils.isWrapperClass(clazz) || clazz.isPrimitive()) {
Object obj =
- getProperty(ConfigurationRepository.lookup().getConfigurationFor(tenant, namespace),
+ ConfigurationUtils
+ .getProperty(ConfigurationRepository.lookup().getConfigurationFor(tenant, namespace),
key, processingHints);
if (obj != null) {
if (ConfigurationUtils.isCollection(obj.toString())) {
return null;
}
} else if (clazz.isArray()
- && (clazz.getComponentType().isPrimitive() || isWrapperClass(clazz.getComponentType()))) {
+ && (clazz.getComponentType().isPrimitive() || ConfigurationUtils.isWrapperClass(clazz.getComponentType()))) {
Object obj =
- getProperty(ConfigurationRepository.lookup().getConfigurationFor(tenant, namespace),
+ ConfigurationUtils
+ .getProperty(ConfigurationRepository.lookup().getConfigurationFor(tenant, namespace),
key, processingHints);
if (obj != null) {
Class componentClass = clazz.getComponentType();
private <T> T read(String tenant, String namespace, Class<T> clazz, String keyPrefix,
Hint... hints) throws Exception {
- org.openecomp.config.api.Config confAnnot =
- clazz.getAnnotation(org.openecomp.config.api.Config.class);
+ Config confAnnot =
+ clazz.getAnnotation(Config.class);
if (confAnnot != null && confAnnot.key().length()>0 && !keyPrefix.endsWith(".")) {
keyPrefix += (confAnnot.key() + ".");
}
T objToReturn = constructor.newInstance();
for (Field field : clazz.getDeclaredFields()) {
field.setAccessible(true);
- org.openecomp.config.api.Config fieldConfAnnot =
- field.getAnnotation(org.openecomp.config.api.Config.class);
+ Config fieldConfAnnot =
+ field.getAnnotation(Config.class);
if (fieldConfAnnot != null) {
- if (field.getType().isPrimitive() || isWrapperClass(field.getType())
+ if (field.getType().isPrimitive() || ConfigurationUtils.isWrapperClass(field.getType())
|| (field.getType().isArray() && (field.getType().getComponentType().isPrimitive()
- || isWrapperClass(field.getType().getComponentType())))
- || field.getType().getAnnotation(org.openecomp.config.api.Config.class) != null) {
+ || ConfigurationUtils.isWrapperClass(field.getType().getComponentType())))
+ || field.getType().getAnnotation(Config.class) != null) {
field.set(objToReturn,
get(tenant, namespace, keyPrefix + fieldConfAnnot.key(), field.getType(), hints));
} else if (Collection.class.isAssignableFrom(field.getType())) {
obj = obj.toString().trim();
}
if (String.class.equals(clazz)) {
- if (obj.toString().startsWith("@") && isExternalLookup(processingHint)) {
+ if (obj.toString().startsWith("@") && ConfigurationUtils.isExternalLookup(processingHint)) {
String contents = ConfigurationUtils
.getFileContents(NonConfigResource.locate(obj.toString().substring(1).trim()));
if (contents == null) {
tenantId = tenantId.toUpperCase();
}
if (namespace==null || namespace.trim().length()==0){
- namespace = DEFAULT_NAMESPACE;
+ namespace = Constants.DEFAULT_NAMESPACE;
}else{
namespace = namespace.toUpperCase();
}
Iterator<String> keys ;
try {
if (ConfigurationRepository.lookup().isDBAccessible()){
- keys = ConfigurationUtils.executeSelectSql(ConfigurationRepository.lookup().getConfigurationFor(DEFAULT_TENANT, DB_NAMESPACE).getString("fetchkeysql"), new String[]{tenantId+KEY_ELEMENTS_DELEMETER+namespace}).iterator();
+ keys = ConfigurationUtils.executeSelectSql(ConfigurationRepository.lookup().getConfigurationFor(
+ Constants.DEFAULT_TENANT, Constants.DB_NAMESPACE).getString("fetchkeysql"), new String[]{tenantId+ Constants.KEY_ELEMENTS_DELEMETER+namespace}).iterator();
}else{
keys = ConfigurationRepository.lookup().getConfigurationFor(tenantId, namespace).getKeys(key);
}
tenantId = tenantId.toUpperCase();
}
if (namespace==null || namespace.trim().length()==0){
- namespace = DEFAULT_NAMESPACE;
+ namespace = Constants.DEFAULT_NAMESPACE;
}else{
namespace = namespace.toUpperCase();
}
Iterator<String> keys ;
try {
if (ConfigurationRepository.lookup().isDBAccessible()){
- keys = ConfigurationUtils.executeSelectSql(ConfigurationRepository.lookup().getConfigurationFor(DEFAULT_TENANT, DB_NAMESPACE).getString("fetchkeysql"), new String[]{tenantId+KEY_ELEMENTS_DELEMETER+namespace}).iterator();
+ keys = ConfigurationUtils.executeSelectSql(ConfigurationRepository.lookup().getConfigurationFor(
+ Constants.DEFAULT_TENANT, Constants.DB_NAMESPACE).getString("fetchkeysql"), new String[]{tenantId+ Constants.KEY_ELEMENTS_DELEMETER+namespace}).iterator();
}else{
if (key==null || key.trim().length()==0){
keys = ConfigurationRepository.lookup().getConfigurationFor(tenantId, namespace).getKeys();