diff options
Diffstat (limited to 'common/onap-common-configuration-management/onap-configuration-management-core')
3 files changed, 84 insertions, 53 deletions
diff --git a/common/onap-common-configuration-management/onap-configuration-management-core/src/main/java/org/onap/config/impl/CliConfigurationImpl.java b/common/onap-common-configuration-management/onap-configuration-management-core/src/main/java/org/onap/config/impl/CliConfigurationImpl.java index a2440b9e94..491382ac5b 100644 --- a/common/onap-common-configuration-management/onap-configuration-management-core/src/main/java/org/onap/config/impl/CliConfigurationImpl.java +++ b/common/onap-common-configuration-management/onap-configuration-management-core/src/main/java/org/onap/config/impl/CliConfigurationImpl.java @@ -32,13 +32,17 @@ import java.util.Iterator; import java.util.List; import java.util.Map; import java.util.Set; + import org.onap.config.ConfigurationUtils; import org.onap.config.api.ConfigurationManager; import org.onap.config.api.Hint; import org.onap.config.type.ConfigurationQuery; +import org.slf4j.Logger; +import org.slf4j.LoggerFactory; public final class CliConfigurationImpl extends ConfigurationImpl implements ConfigurationManager { + private static final Logger LOGGER = LoggerFactory.getLogger(CliConfigurationImpl.class); private static final List<String> KEYS_TO_FILTER = Arrays.asList(NAMESPACE_KEY, MODE_KEY, LOAD_ORDER_KEY); public CliConfigurationImpl() { @@ -50,55 +54,49 @@ public final class CliConfigurationImpl extends ConfigurationImpl implements Con } private String getConfigurationValue(ConfigurationQuery queryData) { - - try { - - Hint[] hints = getHints(queryData); - - String[] value; - if (queryData.isFallback()) { - value = get(queryData.getTenant(), queryData.getNamespace(), queryData.getKey(), String[].class, hints); - } else { - value = getInternal(queryData.getTenant(), queryData.getNamespace(), queryData.getKey(), String[].class, - hints); + if (queryData != null) { + try { + Hint[] hints = getHints(queryData); + String[] value; + if (queryData.isFallback()) { + value = get(queryData.getTenant(), queryData.getNamespace(), queryData.getKey(), String[].class, hints); + } else { + value = getInternal(queryData.getTenant(), queryData.getNamespace(), queryData.getKey(), String[].class, + hints); + } + return ConfigurationUtils.getCommaSeparatedList(value); + } catch (Exception exception) { + LOGGER.warn("Error occurred while processing query: {}", queryData, exception); } - - return ConfigurationUtils.getCommaSeparatedList(value); - - } catch (Exception exception) { - exception.printStackTrace(); } - return null; } private Hint[] getHints(ConfigurationQuery query) { List<Hint> hints = new ArrayList<>(Hint.values().length); - hints.add(query.isLatest() ? Hint.LATEST_LOOKUP : Hint.DEFAULT); - hints.add(query.isExternalLookup() ? Hint.EXTERNAL_LOOKUP : Hint.DEFAULT); - hints.add(query.isNodeSpecific() ? Hint.NODE_SPECIFIC : Hint.DEFAULT); + if (query != null) { + hints.add(query.isLatest() ? Hint.LATEST_LOOKUP : Hint.DEFAULT); + hints.add(query.isExternalLookup() ? Hint.EXTERNAL_LOOKUP : Hint.DEFAULT); + hints.add(query.isNodeSpecific() ? Hint.NODE_SPECIFIC : Hint.DEFAULT); + } return hints.toArray(new Hint[0]); } private Object getInput(Map<String, Object> input) { - Object toReturn = null; - - try { - - toReturn = Class.forName(input.get("ImplClass").toString()).newInstance(); - - Method[] methods = toReturn.getClass().getMethods(); - for (Method method : methods) { - if (input.containsKey(method.getName())) { - method.invoke(toReturn, input.get(method.getName())); + if (input != null) { + try { + toReturn = Class.forName(input.get("ImplClass").toString()).newInstance(); + Method[] methods = toReturn.getClass().getMethods(); + for (Method method : methods) { + if (input.containsKey(method.getName())) { + method.invoke(toReturn, input.get(method.getName())); + } } + } catch (Exception exception) { + LOGGER.warn("Error occurred while processing input: {}", input, exception); } - - } catch (Exception exception) { - exception.printStackTrace(); } - return toReturn; } @@ -107,43 +105,37 @@ public final class CliConfigurationImpl extends ConfigurationImpl implements Con } private Map<String, String> listConfiguration(ConfigurationQuery query) { - Map<String, String> map = new HashMap<>(); - - try { - - Collection<String> keys = getKeys(query.getTenant(), query.getNamespace()); - for (String key : keys) { - map.put(key, getConfigurationValue(query.key(key))); + if (query != null) { + try { + Collection<String> keys = getKeys(query.getTenant(), query.getNamespace()); + for (String key : keys) { + map.put(key, getConfigurationValue(query.key(key))); + } + } catch (Exception exception) { + LOGGER.warn("Error occurred while processing query: {}", query, exception); } - - } catch (Exception exception) { - exception.printStackTrace(); - return null; } - return map; } private ArrayList<String> getInMemoryKeys(String tenant, String namespace) { - ArrayList<String> keys = new ArrayList<>(); - try { - Iterator<String> iter = ConfigurationRepository.lookup().getConfigurationFor(tenant, namespace).getKeys(); while (iter.hasNext()) { - String key = iter.next(); if (!KEYS_TO_FILTER.contains(key)) { keys.add(key); } } - } catch (Exception exception) { - //do nothing + LOGGER.warn("Error occurred while searching for in-memory keys for namespace: '{}' and tenant: '{}'", + namespace, + tenant, + exception + ); } - return keys; } diff --git a/common/onap-common-configuration-management/onap-configuration-management-core/src/main/java/org/onap/config/type/ConfigurationQuery.java b/common/onap-common-configuration-management/onap-configuration-management-core/src/main/java/org/onap/config/type/ConfigurationQuery.java index faefdb0eb3..ce0657240a 100644 --- a/common/onap-common-configuration-management/onap-configuration-management-core/src/main/java/org/onap/config/type/ConfigurationQuery.java +++ b/common/onap-common-configuration-management/onap-configuration-management-core/src/main/java/org/onap/config/type/ConfigurationQuery.java @@ -95,4 +95,17 @@ public class ConfigurationQuery { public boolean isLatest() { return latest; } + + @Override + public String toString() { + return "ConfigurationQuery{" + + "tenant='" + tenant + '\'' + + ", namespace='" + namespace + '\'' + + ", key='" + key + '\'' + + ", fallback=" + fallback + + ", externalLookup=" + externalLookup + + ", latest=" + latest + + ", nodeSpecific=" + nodeSpecific + + '}'; + } } diff --git a/common/onap-common-configuration-management/onap-configuration-management-core/src/test/java/org/onap/config/CliConfigurationImpTest.java b/common/onap-common-configuration-management/onap-configuration-management-core/src/test/java/org/onap/config/CliConfigurationImpTest.java index 3d12eac13d..897583f605 100644 --- a/common/onap-common-configuration-management/onap-configuration-management-core/src/test/java/org/onap/config/CliConfigurationImpTest.java +++ b/common/onap-common-configuration-management/onap-configuration-management-core/src/test/java/org/onap/config/CliConfigurationImpTest.java @@ -19,8 +19,10 @@ package org.onap.config; import static org.junit.Assert.assertEquals; import static org.junit.Assert.assertTrue; +import java.util.HashMap; import java.util.Map; +import org.junit.Assert; import org.junit.Test; import org.onap.config.api.ConfigurationManager; import org.onap.config.impl.CliConfigurationImpl; @@ -51,6 +53,30 @@ public class CliConfigurationImpTest { assertEquals("org.junit.Test", testServiceImpl.getImplementationClass()); } + @Test + public void listConfigurationNullQueryShouldntFailWithNPETest() { + ConfigurationManager conf = new CliConfigurationImpl(); + Assert.assertEquals(0, conf.listConfiguration(null).size()); + } + + @Test + public void listConfigurationEmptyQueryTest() { + ConfigurationManager conf = new CliConfigurationImpl(); + Assert.assertEquals(0, conf.listConfiguration(new HashMap<>()).size()); + } + + @Test + public void getConfigurationValueNullQueryShouldntFailWithNPETest() { + ConfigurationManager conf = new CliConfigurationImpl(); + Assert.assertNull (conf.getConfigurationValue(null)); + } + + @Test + public void getConfigurationValueEmptyQueryTest() { + ConfigurationManager conf = new CliConfigurationImpl(); + Assert.assertNull (conf.getConfigurationValue(new HashMap<>())); + } + private void validateCliMapConfig(Map outputMap) { assertEquals("appc", outputMap.get(withoutArtifactPrefix(ConfigTestConstant.ARTIFACT_CONSUMER))); |