diff options
Diffstat (limited to 'UniversalVesAdapter/src/main/java/org/onap/universalvesadapter/utils/FetchDynamicConfig.java')
-rw-r--r-- | UniversalVesAdapter/src/main/java/org/onap/universalvesadapter/utils/FetchDynamicConfig.java | 24 |
1 files changed, 8 insertions, 16 deletions
diff --git a/UniversalVesAdapter/src/main/java/org/onap/universalvesadapter/utils/FetchDynamicConfig.java b/UniversalVesAdapter/src/main/java/org/onap/universalvesadapter/utils/FetchDynamicConfig.java index f515858..af219ce 100644 --- a/UniversalVesAdapter/src/main/java/org/onap/universalvesadapter/utils/FetchDynamicConfig.java +++ b/UniversalVesAdapter/src/main/java/org/onap/universalvesadapter/utils/FetchDynamicConfig.java @@ -32,17 +32,16 @@ import org.json.JSONObject; import org.json.JSONTokener; import org.slf4j.Logger; import org.slf4j.LoggerFactory; +import org.springframework.stereotype.Component; import com.fasterxml.jackson.databind.JsonNode; import com.fasterxml.jackson.databind.ObjectMapper; +@Component public class FetchDynamicConfig { private static final Logger debugLogger = LoggerFactory.getLogger("debugLogger"); private static final Logger errorLogger = LoggerFactory.getLogger("errorLogger"); - // need to change below path - public static String configFile = "/opt/app/VESAdapter/conf/kv.json"; - //public static String configFile = "src\\main\\resources\\kv.json"; private static String url; public static String retString; public static String retCBSString; @@ -51,7 +50,7 @@ public class FetchDynamicConfig { public FetchDynamicConfig() { } - public static void cbsCall() { + public static void cbsCall(String configFile) { env = System.getenv(); Boolean areEqual; @@ -60,11 +59,11 @@ public class FetchDynamicConfig { // Construct and invoke CBS API to get application Configuration getCBS(); // Verify if data has changed - areEqual = verifyConfigChange(); + areEqual = verifyConfigChange(configFile); if (!areEqual) { FetchDynamicConfig fc = new FetchDynamicConfig(); - fc.writefile(retCBSString); + fc.writefile(retCBSString,configFile); } else { debugLogger.info("New config pull results identical - " + configFile + " NOT refreshed"); } @@ -73,16 +72,11 @@ public class FetchDynamicConfig { private static void getconsul() { url = env.get("CONSUL_HOST") + ":8500/v1/catalog/service/" + env.get("CONFIG_BINDING_SERVICE"); - - // for testing :url="10.12.6.50:8500/v1/catalog/service/config_binding_service"; - //http://10.12.6.44:8500/v1/catlog/service/config_binding_service - retString = executecurl(url); debugLogger.info("CBS details fetched from Consul"); - } - public static boolean verifyConfigChange() { + public static boolean verifyConfigChange(String configFile) { boolean areEqual = false; // Read current data @@ -138,12 +132,12 @@ public class FetchDynamicConfig { } - public void writefile(String retCBSString) { + public void writefile(String retCBSString, String configFile) { debugLogger.info("URL to fetch configuration:" + url); String indentedretstring = (new JSONObject(retCBSString)).toString(4); - try (FileWriter file = new FileWriter(FetchDynamicConfig.configFile)) { + try (FileWriter file = new FileWriter(configFile)) { file.write(indentedretstring); debugLogger.info("Successfully Copied JSON Object to file " + configFile); @@ -189,8 +183,6 @@ public class FetchDynamicConfig { builder.append(line); } result = builder.toString(); - debugLogger.info(result); - reader.close(); ipr.close(); } catch (IOException e) { |