Migrating the kpi.config from app-config file to separate policy module 41/123341/3 1.0.1-kpi-computation-ms
authorHariharan <rh20085046@wipro.com>
Wed, 18 Aug 2021 09:25:48 +0000 (14:55 +0530)
committerHariharan <rh20085046@wipro.com>
Fri, 27 Aug 2021 07:12:20 +0000 (12:42 +0530)
Issue-ID: DCAEGEN2-2835
Signed-off-by: Hariharan <rh20085046@wipro.com>
Change-Id: I06d7829031b865e3eaa2b37b81116531a4a677d5

components/kpi-computation-ms/Changelog.md [new file with mode: 0644]
components/kpi-computation-ms/pom.xml
components/kpi-computation-ms/src/main/java/org/onap/dcaegen2/kpi/controller/ConfigFetchFromCbs.java
components/kpi-computation-ms/src/main/java/org/onap/dcaegen2/kpi/models/Configuration.java
components/kpi-computation-ms/src/test/java/org/onap/dcaegen2/kpi/models/ConfigurationTest.java

diff --git a/components/kpi-computation-ms/Changelog.md b/components/kpi-computation-ms/Changelog.md
new file mode 100644 (file)
index 0000000..357ea9d
--- /dev/null
@@ -0,0 +1,12 @@
+# Change Log
+
+All notable changes to this project will be documented in this file.
+
+The format is based on [Keep a Changelog](http://keepachangelog.com/)
+and this project adheres to [Semantic Versioning](http://semver.org/).
+
+## [1.0.1]
+### Changed
+* Migrating the kpi.policy from app-config file to separate policy module (DCAEGEN2-2835)
+
+
index d8e8f4d..a0265c0 100644 (file)
@@ -36,7 +36,7 @@
 
     <properties>
         <java.version>11</java.version>
-        <sdk.version>1.5.0</sdk.version>
+        <sdk.version>1.8.7</sdk.version>
         <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
         <maven.compiler.source>11</maven.compiler.source>
         <maven.compiler.target>11</maven.compiler.target>
index ba8e33e..3ac0ef3 100644 (file)
@@ -97,6 +97,8 @@ public class ConfigFetchFromCbs implements Runnable {
                     if (jsonObject.getAsJsonObject("policies") != null) {
                         JsonObject policyJson = jsonObject.getAsJsonObject("policies").getAsJsonArray("items").get(0)
                                 .getAsJsonObject().getAsJsonObject("config");
+                        log.info("policy json {}", policyJson);
+                        Configuration.getInstance().updateConfigFromPolicy(policyJson);
                         Map<String, Object> policy = new Gson().fromJson(policyJson, mapType);
                         configPolicy.setConfig(policy);
                         log.info("Config policy {}", configPolicy);
index 930e631..dbad392 100644 (file)
 
 package org.onap.dcaegen2.kpi.models;
 
-import com.google.gson.Gson;
-import com.google.gson.JsonArray;
-import com.google.gson.JsonObject;
-import com.google.gson.reflect.TypeToken;
-
 import java.lang.reflect.Type;
 import java.util.List;
 import java.util.Map;
@@ -32,6 +27,11 @@ import java.util.Map;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
+import com.google.gson.Gson;
+import com.google.gson.JsonArray;
+import com.google.gson.JsonObject;
+import com.google.gson.reflect.TypeToken;
+
 /**
  * Model class for the application Configuration.
  */
@@ -259,6 +259,11 @@ public class Configuration {
         log.info("configuration from CBS {}", this);
 
     }
+    
+    public void updateConfigFromPolicy(JsonObject policyconfig) {
+           kpiConfig = policyconfig.toString();
+           log.info("kpi config fetched from policy {}", kpiConfig);
+    }
 
     public String getKpiConfig() {
         return kpiConfig;
index 07ef51d..efe8498 100644 (file)
@@ -30,10 +30,12 @@ import java.util.List;
 import java.util.Map;
 
 import org.junit.Test;
+import org.onap.dcaegen2.kpi.computation.FileUtils;
 
 
 public class ConfigurationTest {
     Configuration configuration = Configuration.getInstance();
+    private static final String KPI_CONFIG_FILE = "kpi/kpi_config.json";
 
     @Test
     public void configurationTest() {
@@ -76,4 +78,11 @@ public class ConfigurationTest {
         assertEquals("kpi config", configuration.getKpiConfig());    
         assertEquals(10, configuration.getCbsPollingInterval());    
     }
+    
+    @Test
+    public void updateConfigFromPolicyTest() {
+       String strKpiConfig = FileUtils.getFileContents(KPI_CONFIG_FILE);
+       configuration.setKpiConfig(strKpiConfig);
+       assertEquals(strKpiConfig, configuration.getKpiConfig());
+    }
 }