Fix config policy 68/84368/2
authorsebdet <sebastien.determe@intl.att.com>
Fri, 5 Apr 2019 16:00:51 +0000 (18:00 +0200)
committersebdet <sebastien.determe@intl.att.com>
Mon, 8 Apr 2019 08:39:14 +0000 (10:39 +0200)
Fix saving of config policy due to refactoring + fix missing model
type in config policy

Issue-ID: CLAMP-303
Change-Id: I863f3bb6b2acef8ed7bf534e142c1730b1493b67
Signed-off-by: sebdet <sebastien.determe@intl.att.com>
src/main/java/org/onap/clamp/clds/sdc/controller/installer/BlueprintParser.java
src/main/java/org/onap/clamp/policy/microservice/MicroservicePolicyService.java
src/test/java/org/onap/clamp/clds/sdc/controller/installer/BlueprintParserTest.java
src/test/resources/example/sdc/blueprint-dcae/tca.yaml
src/test/resources/example/sdc/blueprint-dcae/tca_2.yaml
src/test/resources/example/sdc/blueprint-dcae/tca_3.yaml

index f365459..93374fe 100644 (file)
@@ -87,7 +87,8 @@ public class BlueprintParser {
             }
         }
         String msName = theBiggestMicroServiceKey.toLowerCase().contains(HOLMES_PREFIX) ? HOLMES : TCA;
-        return Collections.singletonList(new MicroService(msName, "", "", "", ""));
+        return Collections
+            .singletonList(new MicroService(msName, "onap.policy.monitoring.cdap.tca.hi.lo.ap", "", "", ""));
     }
 
     String getName(Entry<String, JsonElement> entry) {
index b14e145..59ddaa0 100644 (file)
@@ -65,9 +65,10 @@ public class MicroservicePolicyService implements PolicyService<MicroServicePoli
      * @return The updated MicroService policy
      */
     public MicroServicePolicy getAndUpdateMicroServicePolicy(Loop loop, MicroServicePolicy policy) {
-        return repository.findById(policy.getName()).map(p -> updateMicroservicePolicyProperties(p, policy, loop))
-            .orElse(new MicroServicePolicy(policy.getName(), policy.getModelType(), policy.getPolicyTosca(),
-                policy.getShared(), policy.getJsonRepresentation(), Sets.newHashSet(loop)));
+        return repository
+            .save(repository.findById(policy.getName()).map(p -> updateMicroservicePolicyProperties(p, policy, loop))
+                .orElse(new MicroServicePolicy(policy.getName(), policy.getModelType(), policy.getPolicyTosca(),
+                    policy.getShared(), policy.getJsonRepresentation(), Sets.newHashSet(loop))));
     }
 
     private MicroServicePolicy updateMicroservicePolicyProperties(MicroServicePolicy oldPolicy,
index fbe6e63..93d7166 100644 (file)
@@ -163,7 +163,8 @@ public class BlueprintParserTest {
 
     @Test
     public void fallBackToOneMicroServiceTCATest() {
-        MicroService tcaMS = new MicroService(BlueprintParser.TCA, "", "", "", "");
+        MicroService tcaMS = new MicroService(BlueprintParser.TCA, "onap.policy.monitoring.cdap.tca.hi.lo.ap", "", "",
+            "");
 
         List<MicroService> expected = Collections.singletonList(tcaMS);
         List<MicroService> actual = new BlueprintParser().fallbackToOneMicroService(microServiceBlueprintOldStyleTCA);
@@ -173,7 +174,8 @@ public class BlueprintParserTest {
 
     @Test
     public void fallBackToOneMicroServiceHolmesTest() {
-        MicroService holmesMS = new MicroService(BlueprintParser.HOLMES, "", "", "", "");
+        MicroService holmesMS = new MicroService(BlueprintParser.HOLMES, "onap.policy.monitoring.cdap.tca.hi.lo.ap", "",
+            "", "");
 
         List<MicroService> expected = Collections.singletonList(holmesMS);
         List<MicroService> actual = new BlueprintParser()
index 0ab8317..b165907 100644 (file)
@@ -17,6 +17,7 @@ node_templates:
     properties:
       policy_id: 
         get_input: policy_id
+        policy_type_id: onap.policy.monitoring.cdap.tca.hi.lo.ap
   cdap_host_host:
     type: dcae.nodes.StreamingAnalytics.SelectedCDAPInfrastructure
     properties:
index f73119f..5590136 100644 (file)
@@ -166,4 +166,5 @@ node_templates:
     properties:
       policy_id:
            get_input: policy_id
+           policy_type_id: onap.policy.monitoring.cdap.tca.hi.lo.ap
 
index 0ab8317..b165907 100644 (file)
@@ -17,6 +17,7 @@ node_templates:
     properties:
       policy_id: 
         get_input: policy_id
+        policy_type_id: onap.policy.monitoring.cdap.tca.hi.lo.ap
   cdap_host_host:
     type: dcae.nodes.StreamingAnalytics.SelectedCDAPInfrastructure
     properties: