diff options
3 files changed, 172 insertions, 128 deletions
diff --git a/feature-lifecycle/src/main/java/org/onap/policy/drools/lifecycle/LifecycleFsm.java b/feature-lifecycle/src/main/java/org/onap/policy/drools/lifecycle/LifecycleFsm.java index 3cec7451..1326c3b0 100644 --- a/feature-lifecycle/src/main/java/org/onap/policy/drools/lifecycle/LifecycleFsm.java +++ b/feature-lifecycle/src/main/java/org/onap/policy/drools/lifecycle/LifecycleFsm.java @@ -53,7 +53,6 @@ import org.onap.policy.common.endpoints.listeners.MessageTypeDispatcher; import org.onap.policy.common.endpoints.listeners.ScoListener; import org.onap.policy.common.gson.annotation.GsonJsonIgnore; import org.onap.policy.common.utils.coder.StandardCoderObject; -import org.onap.policy.drools.metrics.Metric; import org.onap.policy.drools.persistence.SystemPersistenceConstants; import org.onap.policy.drools.policies.DomainMaker; import org.onap.policy.drools.system.PolicyController; @@ -446,8 +445,8 @@ public class LifecycleFsm implements Startable { policiesMap.computeIfPresent(policy.getIdentifier(), (key, value) -> { // avoid counting reapplies in a second pass when a mix of native and non-native // policies are present. - getStats().setPolicyDeployCount(getStats().getPolicyDeployCount() + 1); - getStats().setPolicyDeploySuccessCount(getStats().getPolicyDeploySuccessCount() + 1); + getStats().setPolicyUndeployCount(getStats().getPolicyUndeployCount() + 1); + getStats().setPolicyUndeploySuccessCount(getStats().getPolicyUndeploySuccessCount() + 1); return null; }); } @@ -458,7 +457,8 @@ public class LifecycleFsm implements Startable { } protected void failedUndeployPolicyAction(ToscaPolicy failedPolicy) { - failedDeployPolicyAction(failedPolicy); + getStats().setPolicyUndeployCount(getStats().getPolicyUndeployCount() + 1); + getStats().setPolicyUndeployFailCount(getStats().getPolicyUndeployFailCount() + 1); policiesMap.remove(failedPolicy.getIdentifier()); } @@ -477,14 +477,24 @@ public class LifecycleFsm implements Startable { } } - protected void resetDeployCountsAction() { - getStats().setPolicyDeployCount(0); - getStats().setPolicyDeployFailCount(0); - getStats().setPolicyDeploySuccessCount(0); + protected void updateUndeployCountsAction(Long undeployCount, Long undeploySuccesses, Long undeployFailures) { + PdpStatistics statistics = getStats(); + if (undeployCount != null) { + statistics.setPolicyUndeployCount(undeployCount); + } + + if (undeploySuccesses != null) { + statistics.setPolicyUndeploySuccessCount(undeploySuccesses); + } + + if (undeployFailures != null) { + statistics.setPolicyUndeployFailCount(undeployFailures); + } } protected List<ToscaPolicy> resetPoliciesAction() { - resetDeployCountsAction(); + updateDeployCountsAction(0L, 0L, 0L); + updateUndeployCountsAction(0L, 0L, 0L); List<ToscaPolicy> policies = new ArrayList<>(getActivePolicies()); policiesMap.clear(); return policies; diff --git a/feature-lifecycle/src/test/java/org/onap/policy/drools/lifecycle/LifecycleFsmTest.java b/feature-lifecycle/src/test/java/org/onap/policy/drools/lifecycle/LifecycleFsmTest.java index 4479aa12..7201d62e 100644 --- a/feature-lifecycle/src/test/java/org/onap/policy/drools/lifecycle/LifecycleFsmTest.java +++ b/feature-lifecycle/src/test/java/org/onap/policy/drools/lifecycle/LifecycleFsmTest.java @@ -1,6 +1,7 @@ /* * ============LICENSE_START======================================================= * Copyright (C) 2021 AT&T Intellectual Property. All rights reserved. + * Modifications Copyright (C) 2021 Nordix Foundation. * ================================================================================ * Licensed under the Apache License, Version 2.0 (the "License"); * you may not use this file except in compliance with the License. @@ -35,7 +36,6 @@ import org.junit.Before; import org.junit.Test; import org.onap.policy.common.utils.coder.CoderException; import org.onap.policy.common.utils.coder.StandardCoder; -import org.onap.policy.common.utils.network.NetworkUtil; import org.onap.policy.common.utils.resources.ResourceUtils; import org.onap.policy.common.utils.time.PseudoScheduledExecutorService; import org.onap.policy.common.utils.time.TestTimeMulti; @@ -126,7 +126,7 @@ public class LifecycleFsmTest { unvalPolicy = getPolicyFromFile(EXAMPLE_OTHER_UNVAL_POLICY_JSON, EXAMPLE_OTHER_UNVAL_POLICY_NAME); - fsm.resetDeployCountsAction(); + fsm.resetPoliciesAction(); resetExecutionStats(); } @@ -210,15 +210,21 @@ public class LifecycleFsmTest { assertEquals(1, fsm.getStats().getPolicyDeploySuccessCount()); fsm.undeployedPolicyAction(controllerPolicy); - assertEquals(2, fsm.getStats().getPolicyDeploySuccessCount()); + assertEquals(1, fsm.getStats().getPolicyDeploySuccessCount()); + assertEquals(1, fsm.getStats().getPolicyUndeploySuccessCount()); + + fsm.resetPoliciesAction(); + assertEquals(0, fsm.getStats().getPolicyUndeployCount()); + assertEquals(0, fsm.getStats().getPolicyUndeploySuccessCount()); } @Test public void testRestDeployCountsAction() { deployAllPolicies(); assertEquals(8, fsm.getStats().getPolicyDeploySuccessCount()); + assertEquals(0, fsm.getStats().getPolicyUndeployCount()); - fsm.resetDeployCountsAction(); + fsm.resetPoliciesAction(); assertEquals(0, fsm.getStats().getPolicyDeploySuccessCount()); assertEquals(0, fsm.getStats().getPolicyDeployFailCount()); assertEquals(0, fsm.getStats().getPolicyDeployCount()); @@ -228,6 +234,7 @@ public class LifecycleFsmTest { public void testStatusPayload() { setExecutionCounts(); fsm.updateDeployCountsAction(8L, 6L, 2L); + fsm.updateUndeployCountsAction(4L, 3L, 1L); PdpStatus status = fsm.statusPayload(PdpState.ACTIVE); assertEquals(fsm.getGroup(), status.getStatistics().getPdpGroupName()); @@ -240,6 +247,9 @@ public class LifecycleFsmTest { assertEquals(7, status.getStatistics().getPolicyExecutedCount()); assertEquals(2, status.getStatistics().getPolicyExecutedFailCount()); assertEquals(5, status.getStatistics().getPolicyExecutedSuccessCount()); + assertEquals(3, status.getStatistics().getPolicyUndeploySuccessCount()); + assertEquals(1, status.getStatistics().getPolicyUndeployFailCount()); + assertEquals(4, status.getStatistics().getPolicyUndeployCount()); } @Test @@ -268,6 +278,38 @@ public class LifecycleFsmTest { fsm.getPolicyIds(List.of(opPolicy, controllerPolicy)).toString()); } + @Test + public void testUpdateCountsAction() { + fsm.resetPoliciesAction(); + + assertDeployUndeployValues(0, 0, 0, 0, 0, 0); + + fsm.updateDeployCountsAction(3L, 2L, 1L); + assertDeployUndeployValues(3, 2, 1, 0, 0, 0); + + fsm.updateUndeployCountsAction(1L, 1L, 0L); + assertDeployUndeployValues(3, 2, 1, 1, 1, 0); + + // shouldn't update values + fsm.updateDeployCountsAction(null, null, null); + fsm.updateUndeployCountsAction(null, null, null); + + assertDeployUndeployValues(3, 2, 1, 1, 1, 0); + fsm.resetPoliciesAction(); + + assertDeployUndeployValues(0, 0, 0, 0, 0, 0); + } + + protected void assertDeployUndeployValues(long deployCount, long deploySuccess, long deployFail, + long undeployCount, long undeploySuccess, long undeployFail) { + assertEquals(deployCount, fsm.getStats().getPolicyDeployCount()); + assertEquals(deploySuccess, fsm.getStats().getPolicyDeploySuccessCount()); + assertEquals(deployFail, fsm.getStats().getPolicyDeployFailCount()); + assertEquals(undeployCount, fsm.getStats().getPolicyUndeployCount()); + assertEquals(undeploySuccess, fsm.getStats().getPolicyUndeploySuccessCount()); + assertEquals(undeployFail, fsm.getStats().getPolicyUndeployFailCount()); + } + protected void deployAllPolicies() { fsm.deployedPolicyAction(controllerPolicy); fsm.deployedPolicyAction(controller2Policy); diff --git a/feature-lifecycle/src/test/java/org/onap/policy/drools/lifecycle/LifecycleFsmUpdateTest.java b/feature-lifecycle/src/test/java/org/onap/policy/drools/lifecycle/LifecycleFsmUpdateTest.java index 253ca5db..15af959a 100644 --- a/feature-lifecycle/src/test/java/org/onap/policy/drools/lifecycle/LifecycleFsmUpdateTest.java +++ b/feature-lifecycle/src/test/java/org/onap/policy/drools/lifecycle/LifecycleFsmUpdateTest.java @@ -80,8 +80,7 @@ public class LifecycleFsmUpdateTest { "src/test/resources/tosca-policy-other-unvalidated.json"; private static final String EXAMPLE_OTHER_VAL_POLICY_NAME = "other-validated"; - private static final String EXAMPLE_OTHER_VAL_POLICY_JSON = - "src/test/resources/tosca-policy-other-validated.json"; + private static final String EXAMPLE_OTHER_VAL_POLICY_JSON = "src/test/resources/tosca-policy-other-validated.json"; private static final String FOO_NATIVE_CONTROLLER_POLICY_NAME = "foo.controller"; private static final String FOO_NATIVE_CONTROLLER_POLICY_JSON = @@ -124,6 +123,7 @@ public class LifecycleFsmUpdateTest { SystemPersistenceConstants.getManager().setConfigurationDir("target/test-classes"); + // @formatter:off ControllerSupport.installArtifact( Paths.get(ControllerSupport.JUNIT_KMODULE_PATH).toFile(), Paths.get(ControllerSupport.JUNIT_KMODULE_POM_PATH).toFile(), @@ -135,6 +135,7 @@ public class LifecycleFsmUpdateTest { Paths.get("src/test/resources/echo.pom").toFile(), "src/main/resources/kbecho/org/onap/policy/drools/test/", List.of(Paths.get("src/test/resources/echo.drl").toFile())); + // @formatter:on Properties noopTopicProperties = new Properties(); noopTopicProperties.put(PolicyEndPointProperties.PROPERTY_NOOP_SOURCE_TOPICS, "DCAE_TOPIC"); @@ -155,11 +156,11 @@ public class LifecycleFsmUpdateTest { NoopTopicFactories.getSinkFactory().destroy(); try { Files.deleteIfExists(Paths.get(SystemPersistenceConstants.getManager().getConfigurationPath().toString(), - "lifecycle-controller.properties.bak")); + "lifecycle-controller.properties.bak")); Files.deleteIfExists(Paths.get(SystemPersistenceConstants.getManager().getConfigurationPath().toString(), "foo-controller.properties.bak")); } catch (IOException ignored) { // NOSONAR - ; // checkstyle + ; // checkstyle } ControllerSupport.setStaticField(LifecycleFeature.class, "fsm", savedFsm); @@ -172,7 +173,7 @@ public class LifecycleFsmUpdateTest { public void init() throws CoderException, IOException, NoSuchFieldException, IllegalAccessException { fsm = new LifecycleFsm() { @Override - protected ScheduledExecutorService makeExecutor() { // NOSONAR + protected ScheduledExecutorService makeExecutor() { // NOSONAR return new PseudoScheduledExecutorService(new TestTimeMulti()); } }; @@ -197,15 +198,12 @@ public class LifecycleFsmUpdateTest { opPolicy = getExamplesPolicy(VFW_OPERATIONAL_DROOLS_POLICY_JSON, VFW_OP_POLICY_NAME); op2Policy = getExamplesPolicy(VCPE_OPERATIONAL_DROOLS_POLICY_JSON, VCPE_OP_POLICY_NAME); controllerPolicy = - getPolicyFromFile(EXAMPLE_NATIVE_CONTROLLER_POLICY_JSON, EXAMPLE_NATIVE_CONTROLLER_POLICY_NAME); + getPolicyFromFile(EXAMPLE_NATIVE_CONTROLLER_POLICY_JSON, EXAMPLE_NATIVE_CONTROLLER_POLICY_NAME); controller2Policy = getPolicyFromFile(FOO_NATIVE_CONTROLLER_POLICY_JSON, FOO_NATIVE_CONTROLLER_POLICY_NAME); - artifactPolicy = - getPolicyFromFile(EXAMPLE_NATIVE_ARTIFACT_POLICY_JSON, EXAMPLE_NATIVE_ARTIFACT_POLICY_NAME); + artifactPolicy = getPolicyFromFile(EXAMPLE_NATIVE_ARTIFACT_POLICY_JSON, EXAMPLE_NATIVE_ARTIFACT_POLICY_NAME); artifact2Policy = getExamplesPolicy(FOO_NATIVE_ARTIFACT_POLICY_JSON, FOO_NATIVE_ARTIFACT_POLICY_NAME); - valPolicy = - getPolicyFromFile(EXAMPLE_OTHER_VAL_POLICY_JSON, EXAMPLE_OTHER_VAL_POLICY_NAME); - unvalPolicy = - getPolicyFromFile(EXAMPLE_OTHER_UNVAL_POLICY_JSON, EXAMPLE_OTHER_UNVAL_POLICY_NAME); + valPolicy = getPolicyFromFile(EXAMPLE_OTHER_VAL_POLICY_JSON, EXAMPLE_OTHER_VAL_POLICY_NAME); + unvalPolicy = getPolicyFromFile(EXAMPLE_OTHER_UNVAL_POLICY_JSON, EXAMPLE_OTHER_UNVAL_POLICY_NAME); } @Test @@ -214,16 +212,16 @@ public class LifecycleFsmUpdateTest { // native controller policy - deploy // Delta: +controllerPolicy - deltaUpdate(List.of(controllerPolicy), List.of(), List.of(controllerPolicy), 1, 1, 0); + deltaUpdate(List.of(controllerPolicy), List.of(), List.of(controllerPolicy), 1, 1, 0, 0, 0, 0); // no policies - undeploy // Delta: -controllerPolicy - deltaUpdate(List.of(), List.of(controllerPolicy), List.of(), 2, 2, 0); + deltaUpdate(List.of(), List.of(controllerPolicy), List.of(), 1, 1, 0, 1, 1, 0); // native controller + artifact policy (out of order) - deploy // Delta: +artifactPolicy, +controllerPolicy - deltaUpdate(List.of(artifactPolicy, controllerPolicy), List.of(), - List.of(artifactPolicy, controllerPolicy), 4, 4, 0); + deltaUpdate(List.of(artifactPolicy, controllerPolicy), List.of(), List.of(artifactPolicy, controllerPolicy), 3, + 3, 0, 1, 1, 0); // attempt to deploy opPolicy but invalid controller // Delta: +opPolicy @@ -231,77 +229,75 @@ public class LifecycleFsmUpdateTest { assertEquals(1, PolicyControllerConstants.getFactory().inventory().size()); assertFalse(fsm.getActivePolicies().contains(opPolicy)); verifyExists(false, "lifecycle", List.of(opPolicy)); - verifyDeploy(List.of(artifactPolicy, controllerPolicy), 5, 4, 1); + verifyDeploy(List.of(artifactPolicy, controllerPolicy), 4, 3, 1, 1, 1, 0); // Delta: +opPolicy opPolicy.getProperties().remove("controllerName"); - deltaUpdate(List.of(opPolicy), List.of(), - List.of(opPolicy, artifactPolicy, controllerPolicy), 6, 5, 1); + deltaUpdate(List.of(opPolicy), List.of(), List.of(opPolicy, artifactPolicy, controllerPolicy), 5, 4, 1, 1, 1, + 0); verifyExists(true, "lifecycle", List.of(opPolicy)); // Delta: -opPolicy - deltaUpdate(List.of(), List.of(opPolicy), - List.of(controllerPolicy, artifactPolicy), 7, 6, 1); + deltaUpdate(List.of(), List.of(opPolicy), List.of(controllerPolicy, artifactPolicy), 5, 4, 1, 2, 2, 0); assertFalse(PolicyControllerConstants.getFactory().get("lifecycle").getDrools().exists(opPolicy)); // Delta: -artifactPolicy - deltaUpdate(List.of(), List.of(artifactPolicy), List.of(controllerPolicy), 8, 7, 1); + deltaUpdate(List.of(), List.of(artifactPolicy), List.of(controllerPolicy), 5, 4, 1, 3, 3, 0); assertFalse(PolicyControllerConstants.getFactory().get("lifecycle").getDrools().isBrained()); // Delta: -controllerPolicy - deltaUpdate(List.of(), List.of(controllerPolicy), List.of(), 9, 8, 1); + deltaUpdate(List.of(), List.of(controllerPolicy), List.of(), 5, 4, 1, 4, 4, 0); assertThatIllegalArgumentException().isThrownBy(() -> PolicyControllerConstants.getFactory().get("lifecycle")); // Delta: +controllerPolicy, +artifactPolicy, and +opPolicy deltaUpdate(List.of(opPolicy, artifactPolicy, controllerPolicy), List.of(), - List.of(opPolicy, artifactPolicy, controllerPolicy), 12, 11, 1); + List.of(opPolicy, artifactPolicy, controllerPolicy), 8, 7, 1, 4, 4, 0); verifyExists(true, "lifecycle", List.of(opPolicy)); // Delta: -artifactPolicy assertTrue(fsm.update(getPdpUpdate(List.of(), List.of(artifactPolicy)))); assertEquals(1, PolicyControllerConstants.getFactory().inventory().size()); assertFalse(PolicyControllerConstants.getFactory().get("lifecycle").getDrools().isBrained()); - verifyDeployStats(13, 12, 1); + verifyUndeployStats(5, 5, 0); // Delta: +artifactPolicy // from deltas, all delta updates should be successfully applied - deltaUpdate(List.of(artifactPolicy), List.of(), - List.of(opPolicy, artifactPolicy, controllerPolicy), 14, 13, 1); + deltaUpdate(List.of(artifactPolicy), List.of(), List.of(opPolicy, artifactPolicy, controllerPolicy), 9, 8, 1, 5, + 5, 0); verifyExists(true, "lifecycle", List.of(opPolicy)); // Delta: -controllerPolicy // from deltas, all delta updates should be successfully applied assertTrue(fsm.update(getPdpUpdate(List.of(), List.of(controllerPolicy)))); assertEquals(0, PolicyControllerConstants.getFactory().inventory().size()); - verifyDeployStats(15, 14, 1); + verifyUndeployStats(6, 6, 0); // Delta: +controllerPolicy // from deltas, all delta updates should be successfully applied - deltaUpdate(List.of(controllerPolicy), List.of(), - List.of(opPolicy, artifactPolicy, controllerPolicy), 16, 15, 1); + deltaUpdate(List.of(controllerPolicy), List.of(), List.of(opPolicy, artifactPolicy, controllerPolicy), 10, 9, 1, + 6, 6, 0); verifyExists(true, "lifecycle", List.of(opPolicy)); // Delta: +op2Policy, +controller2Policy // from deltas, all delta updates should be successfully applied op2Policy.getProperties().put("controllerName", "lifecycle"); deltaUpdate(List.of(op2Policy, controller2Policy), List.of(), - List.of(opPolicy, artifactPolicy, controllerPolicy, op2Policy, controller2Policy), - 18, 17, 1); + List.of(opPolicy, artifactPolicy, controllerPolicy, op2Policy, controller2Policy), 12, 11, 1, 6, 6, 0); verifyExists(true, "lifecycle", List.of(opPolicy, op2Policy)); assertFalse(PolicyControllerConstants.getFactory().get("foo").getDrools().isBrained()); // same operation with duplicates - idempotent operation deltaUpdate(List.of(op2Policy, controller2Policy, opPolicy), List.of(valPolicy, unvalPolicy), - List.of(opPolicy, artifactPolicy, controllerPolicy, op2Policy, controller2Policy), - 18, 17, 1); + List.of(opPolicy, artifactPolicy, controllerPolicy, op2Policy, controller2Policy), 12, 11, 1, 6, 6, 0); verifyExists(true, "lifecycle", List.of(opPolicy, op2Policy)); assertFalse(PolicyControllerConstants.getFactory().get("foo").getDrools().isBrained()); // Delta: +artifact2policy, +valPolicy, +unvalPolicy // from deltas, all delta updates should be successfully applied - deltaUpdate(List.of(valPolicy, unvalPolicy, artifact2Policy), List.of(), - List.of(opPolicy, artifactPolicy, controllerPolicy, op2Policy, controller2Policy, valPolicy, - unvalPolicy, artifact2Policy), 21, 20, 1); + deltaUpdate( + List.of(valPolicy, unvalPolicy, artifact2Policy), List.of(), List.of(opPolicy, artifactPolicy, + controllerPolicy, op2Policy, controller2Policy, valPolicy, unvalPolicy, artifact2Policy), + 15, 14, 1, 6, 6, 0); verifyExists(true, "lifecycle", List.of(opPolicy, op2Policy, valPolicy, unvalPolicy)); verifyExists(true, "foo", List.of(valPolicy, unvalPolicy)); verifyExists(false, "foo", List.of(opPolicy, op2Policy)); @@ -309,20 +305,18 @@ public class LifecycleFsmUpdateTest { // Delta: -artifact2Policy, -unvalPolicy // from deltas, all delta updates should be successfully applied, and unvalPolicy disabled deltaUpdate(List.of(), List.of(artifact2Policy, unvalPolicy), - List.of(opPolicy, artifactPolicy, controllerPolicy, op2Policy, controller2Policy, valPolicy), - 23, 22, 1); + List.of(opPolicy, artifactPolicy, controllerPolicy, op2Policy, controller2Policy, valPolicy), 15, 14, 1, + 8, 8, 0); verifyExists(true, "lifecycle", List.of(opPolicy, op2Policy, valPolicy)); verifyExists(false, "lifecycle", List.of(unvalPolicy)); assertFalse(PolicyControllerConstants.getFactory().get("foo").getDrools().isBrained()); // Delta: +artifact2Policy // from deltas, all delta updates should be successfully applied, opPolicy, op2Policy and unvalPolicy - // should be reapplied. + // should be re-applied. assertTrue(fsm.update(getPdpUpdate(List.of(artifact2Policy), List.of()))); - deltaUpdate(List.of(artifact2Policy), List.of(), - List.of(opPolicy, artifactPolicy, controllerPolicy, op2Policy, controller2Policy, - valPolicy, artifact2Policy), - 24, 23, 1); + deltaUpdate(List.of(artifact2Policy), List.of(), List.of(opPolicy, artifactPolicy, controllerPolicy, op2Policy, + controller2Policy, valPolicy, artifact2Policy), 16, 15, 1, 8, 8, 0); verifyExists(true, "lifecycle", List.of(opPolicy, op2Policy, valPolicy)); verifyExists(false, "lifecycle", List.of(unvalPolicy)); verifyExists(true, "foo", List.of(valPolicy)); @@ -339,7 +333,8 @@ public class LifecycleFsmUpdateTest { verifyActivePoliciesWithDisables( List.of(opPolicy, op2Policy, controller2Policy, valPolicy, artifact2Policy, unvalPolicy), List.of(opPolicy.getIdentifier(), op2Policy.getIdentifier())); - verifyDeployStats(27, 26, 1); + verifyDeployStats(17, 16, 1); + verifyUndeployStats(10, 10, 0); // Delta: -opPolicy, -op2Policy, -controller2Policy, -valPolicy, -artifact2Policy, -unvalPolicy // from deltas, -opPolicy and -op2Policy undeploys will fail since there is not controller with that @@ -349,8 +344,9 @@ public class LifecycleFsmUpdateTest { assertThatIllegalArgumentException().isThrownBy(() -> PolicyControllerConstants.getFactory().get("lifecycle")); assertThatIllegalArgumentException().isThrownBy(() -> PolicyControllerConstants.getFactory().get("foo")); assertEquals(0, PolicyControllerConstants.getFactory().inventory().size()); - verifyDeploy(List.of(), 33, 30, 3); + verifyDeploy(List.of(), 17, 16, 1, 16, 14, 2); + verifyFullStats(33, 30, 3); fsm.shutdown(); } @@ -372,22 +368,24 @@ public class LifecycleFsmUpdateTest { } protected void deltaUpdate(List<ToscaPolicy> deploy, List<ToscaPolicy> undeploy, List<ToscaPolicy> active, - long count, long success, long failures) throws CoderException { + long deployCount, long deploySuccess, long deployFail, long undeployCount, long undeploySuccess, + long undeployFail) throws CoderException { assertTrue(fsm.update(getPdpUpdate(deploy, undeploy))); - verifyDeploy(active, count, success, failures); + verifyDeploy(active, deployCount, deploySuccess, deployFail, undeployCount, undeploySuccess, undeployFail); } - private void verifyDeploy(List<ToscaPolicy> active, long count, long success, long failures) - throws CoderException { + private void verifyDeploy(List<ToscaPolicy> active, long deployCount, long deploySuccess, long deployFail, + long undeployCount, long undeploySuccess, long undeployFail) throws CoderException { verifyActivePolicies(active); - verifyDeployStats(count, success, failures); + verifyDeployStats(deployCount, deploySuccess, deployFail); + verifyUndeployStats(undeployCount, undeploySuccess, undeployFail); } protected void verifyExists(boolean exists, String controller, List<ToscaPolicy> policies) { assertTrue(PolicyControllerConstants.getFactory().get(controller).getDrools().isBrained()); for (ToscaPolicy policy : policies) { - assertEquals("ID: " + controller + ":" + policy.getIdentifier(), - exists, PolicyControllerConstants.getFactory().get(controller).getDrools().exists(policy)); + assertEquals("ID: " + controller + ":" + policy.getIdentifier(), exists, + PolicyControllerConstants.getFactory().get(controller).getDrools().exists(policy)); } } @@ -411,7 +409,7 @@ public class LifecycleFsmUpdateTest { Map<String, List<ToscaPolicy>> testPoliciesMap = fsm.groupPoliciesByPolicyType(testPolicies); Map<String, List<ToscaPolicy>> activePolicyMap = fsm.groupPoliciesByPolicyType(fsm.getActivePolicies()); assertEquals(new HashSet<>(activePolicyMap.keySet()), new HashSet<>(testPoliciesMap.keySet())); - for (String key: fsm.groupPoliciesByPolicyType(fsm.getActivePolicies()).keySet()) { + for (String key : fsm.groupPoliciesByPolicyType(fsm.getActivePolicies()).keySet()) { assertEquals(new HashSet<>(activePolicyMap.get(key)), new HashSet<>(testPoliciesMap.get(key))); } @@ -434,8 +432,7 @@ public class LifecycleFsmUpdateTest { protected void verifyNativeArtifactPolicies(List<ToscaPolicy> policies) throws CoderException { // check that a brained controller exists for each native artifact policy for (ToscaPolicy policy : policies) { - NativeArtifactPolicy artifactPolicy = - fsm.getDomainMaker().convertTo(policy, NativeArtifactPolicy.class); + NativeArtifactPolicy artifactPolicy = fsm.getDomainMaker().convertTo(policy, NativeArtifactPolicy.class); String controllerName = artifactPolicy.getProperties().getController().getName(); assertTrue(PolicyControllerConstants.getFactory().get(controllerName).getDrools().isBrained()); assertEquals(artifactPolicy.getProperties().getRulesArtifact().getGroupId(), @@ -447,8 +444,8 @@ public class LifecycleFsmUpdateTest { } } - protected void verifyNonNativePolicy(ToscaPolicy testPolicy, - List<ToscaConceptIdentifier> nativeDisables) throws CoderException { + protected void verifyNonNativePolicy(ToscaPolicy testPolicy, List<ToscaConceptIdentifier> nativeDisables) + throws CoderException { List<ToscaPolicy> nativeArtifactPolicies = fsm.getNativeArtifactPolicies(fsm.groupPoliciesByPolicyType(fsm.getActivePolicies())); @@ -465,28 +462,25 @@ public class LifecycleFsmUpdateTest { for (ToscaPolicy nativePolicy : nativeArtifactPolicies) { NativeArtifactPolicy artifactPolicy = - fsm.getDomainMaker().convertTo(nativePolicy, NativeArtifactPolicy.class); + fsm.getDomainMaker().convertTo(nativePolicy, NativeArtifactPolicy.class); String artifactControllerName = artifactPolicy.getProperties().getController().getName(); // brained controller check assertTrue(artifactControllerName + ":" + testPolicy.getIdentifier(), - PolicyControllerConstants.getFactory().get(artifactControllerName).getDrools().isBrained()); + PolicyControllerConstants.getFactory().get(artifactControllerName).getDrools().isBrained()); // non native tosca policy as a fact in drools - if (PolicyControllerConstants.getFactory() - .get(artifactControllerName).getPolicyTypes().contains(testPolicy.getTypeIdentifier())) { - assertTrue(artifactControllerName + ":" + testPolicy.getIdentifier(), - PolicyControllerConstants.getFactory() - .get(artifactControllerName).getDrools().exists(testPolicy)); + if (PolicyControllerConstants.getFactory().get(artifactControllerName).getPolicyTypes() + .contains(testPolicy.getTypeIdentifier())) { + assertTrue(artifactControllerName + ":" + testPolicy.getIdentifier(), PolicyControllerConstants + .getFactory().get(artifactControllerName).getDrools().exists(testPolicy)); } else { - assertFalse(artifactControllerName + ":" + testPolicy.getIdentifier(), - PolicyControllerConstants.getFactory() - .get(artifactControllerName).getDrools().exists(testPolicy)); + assertFalse(artifactControllerName + ":" + testPolicy.getIdentifier(), PolicyControllerConstants + .getFactory().get(artifactControllerName).getDrools().exists(testPolicy)); } // there should always be a controller policy for each artifact policy - assertEquals(1, - getNativeControllerPolicies(nativeControllerPolicies, artifactControllerName).size()); + assertEquals(1, getNativeControllerPolicies(nativeControllerPolicies, artifactControllerName).size()); } return; @@ -517,6 +511,7 @@ public class LifecycleFsmUpdateTest { // verify that the other brained controllers don't have this non-native policy + // @formatter:off for (NativeArtifactPolicy nativePolicy : getNativeArtifactPoliciesBut(nativeArtifactPolicies, controllerName)) { assertTrue(PolicyControllerConstants.getFactory() @@ -527,6 +522,7 @@ public class LifecycleFsmUpdateTest { .get(nativePolicy.getProperties().getController().getName()) .getDrools().exists(testPolicy)); } + // @formatter:on return; } @@ -543,57 +539,53 @@ public class LifecycleFsmUpdateTest { assertEquals(fail, fsm.getStats().getPolicyDeployFailCount()); } + protected void verifyUndeployStats(long count, long success, long fail) { + assertEquals(count, fsm.getStats().getPolicyUndeployCount()); + assertEquals(success, fsm.getStats().getPolicyUndeploySuccessCount()); + assertEquals(fail, fsm.getStats().getPolicyUndeployFailCount()); + } + + protected void verifyFullStats(long count, long success, long fail) { + assertEquals(count, fsm.getStats().getPolicyDeployCount() + fsm.getStats().getPolicyUndeployCount()); + assertEquals(success, + fsm.getStats().getPolicyDeploySuccessCount() + fsm.getStats().getPolicyUndeploySuccessCount()); + assertEquals(fail, fsm.getStats().getPolicyDeployFailCount() + fsm.getStats().getPolicyUndeployFailCount()); + } + protected List<NativeArtifactPolicy> getNativeArtifactPoliciesBut(List<ToscaPolicy> nativePolicies, - String controllerName) { - return - nativePolicies.stream() - .map(nativePolicy -> { - try { - return fsm.getDomainMaker().convertTo(nativePolicy, NativeArtifactPolicy.class); - } catch (CoderException ex) { - throw new RuntimeException(nativePolicy.getIdentifier().toString(), ex); - } - }) - .filter(nativeArtifactPolicy -> !controllerName.equals(nativeArtifactPolicy - .getProperties() - .getController() - .getName())) - .collect(Collectors.toList()); + String controllerName) { + return nativePolicies.stream().map(nativePolicy -> { + try { + return fsm.getDomainMaker().convertTo(nativePolicy, NativeArtifactPolicy.class); + } catch (CoderException ex) { + throw new RuntimeException(nativePolicy.getIdentifier().toString(), ex); + } + }).filter(nativeArtifactPolicy -> !controllerName + .equals(nativeArtifactPolicy.getProperties().getController().getName())).collect(Collectors.toList()); } protected List<NativeArtifactPolicy> getNativeArtifactPolicies(List<ToscaPolicy> nativePolicies, - String controllerName) { - return - nativePolicies.stream() - .map(nativePolicy -> { - try { - return fsm.getDomainMaker().convertTo(nativePolicy, NativeArtifactPolicy.class); - } catch (CoderException ex) { - throw new RuntimeException(nativePolicy.getIdentifier().toString(), ex); - } - }) - .filter(nativeArtifactPolicy -> controllerName.equals(nativeArtifactPolicy - .getProperties() - .getController() - .getName())) - .collect(Collectors.toList()); + String controllerName) { + return nativePolicies.stream().map(nativePolicy -> { + try { + return fsm.getDomainMaker().convertTo(nativePolicy, NativeArtifactPolicy.class); + } catch (CoderException ex) { + throw new RuntimeException(nativePolicy.getIdentifier().toString(), ex); + } + }).filter(nativeArtifactPolicy -> controllerName + .equals(nativeArtifactPolicy.getProperties().getController().getName())).collect(Collectors.toList()); } protected List<ControllerPolicy> getNativeControllerPolicies(List<ToscaPolicy> nativePolicies, - String controllerName) { - return - nativePolicies.stream() - .map(controllerPolicy -> { - try { - return fsm.getDomainMaker().convertTo(controllerPolicy, ControllerPolicy.class); - } catch (CoderException ex) { - throw new RuntimeException(controllerPolicy.getIdentifier().toString(), ex); - } - }) - .filter(controllerPolicy -> controllerName.equals(controllerPolicy - .getProperties() - .getControllerName())) - .collect(Collectors.toList()); + String controllerName) { + return nativePolicies.stream().map(controllerPolicy -> { + try { + return fsm.getDomainMaker().convertTo(controllerPolicy, ControllerPolicy.class); + } catch (CoderException ex) { + throw new RuntimeException(controllerPolicy.getIdentifier().toString(), ex); + } + }).filter(controllerPolicy -> controllerName.equals(controllerPolicy.getProperties().getControllerName())) + .collect(Collectors.toList()); } protected ToscaPolicy getPolicyFromFile(String filePath, String policyName) throws CoderException, IOException { @@ -608,4 +600,4 @@ public class LifecycleFsmUpdateTest { return serviceTemplate.getToscaTopologyTemplate().getPolicies().get(0).get(policyName); } -}
\ No newline at end of file +} |