THe pdp payload was not good in some particular cases, when the pdp group was containing different subgroups
Issue-ID: CLAMP-813
Signed-off-by: sebdet <sebastien.determe@intl.att.com>
Change-Id: Ie3e53f42827ed90689ed83b4945151cb13f38c9c
import java.util.HashMap;
import java.util.LinkedList;
import java.util.List;
import java.util.HashMap;
import java.util.LinkedList;
import java.util.List;
import java.util.Map.Entry;
import javax.persistence.Transient;
import org.apache.camel.Exchange;
import java.util.Map.Entry;
import javax.persistence.Transient;
import org.apache.camel.Exchange;
public static final ExternalComponentState SENT_AND_DEPLOYED = new ExternalComponentState("SENT_AND_DEPLOYED",
"The policies defined have been created and deployed on the policy engine", 10);
public static final ExternalComponentState UNKNOWN = new ExternalComponentState("UNKNOWN",
public static final ExternalComponentState SENT_AND_DEPLOYED = new ExternalComponentState("SENT_AND_DEPLOYED",
"The policies defined have been created and deployed on the policy engine", 10);
public static final ExternalComponentState UNKNOWN = new ExternalComponentState("UNKNOWN",
- "The current status is not clear. Need to regresh the status to get the current status.", 0);
+ "The current status is not clear. Need to refresh the status to get the current status.", 0);
/**
* Default constructor.
/**
* Default constructor.
* @return The json, payload to send
*/
public static String createPoliciesPayloadPdpGroup(Loop loop) {
* @return The json, payload to send
*/
public static String createPoliciesPayloadPdpGroup(Loop loop) {
- HashMap<String, HashMap<String, List<JsonObject>>> pdpGroupMap = new HashMap<>();
+ Map<String, Map<String, List<JsonObject>>> pdpGroupMap = new HashMap<>();
for (OperationalPolicy opPolicy : loop.getOperationalPolicies()) {
updatePdpGroupMap(opPolicy.getPdpGroup(), opPolicy.getPdpSubgroup(),
opPolicy.getName(),
for (OperationalPolicy opPolicy : loop.getOperationalPolicies()) {
updatePdpGroupMap(opPolicy.getPdpGroup(), opPolicy.getPdpSubgroup(),
opPolicy.getName(),
String pdpSubGroup,
String policyName,
String policyModelVersion,
String pdpSubGroup,
String policyName,
String policyModelVersion,
- HashMap<String, HashMap<String,
+ Map<String, Map<String,
List<JsonObject>>> pdpGroupMap) {
JsonObject policyJson = new JsonObject();
policyJson.addProperty("name", policyName);
policyJson.addProperty("version", policyModelVersion);
List<JsonObject>>> pdpGroupMap) {
JsonObject policyJson = new JsonObject();
policyJson.addProperty("name", policyName);
policyJson.addProperty("version", policyModelVersion);
- HashMap<String, List<JsonObject>> pdpSubGroupMap;
+ Map<String, List<JsonObject>> pdpSubGroupMap;
List<JsonObject> policyList;
if (pdpGroupMap.get(pdpGroup) == null) {
List<JsonObject> policyList;
if (pdpGroupMap.get(pdpGroup) == null) {
- pdpSubGroupMap = new HashMap<String, List<JsonObject>>();
- policyList = new LinkedList<JsonObject>();
+ pdpSubGroupMap = new HashMap<>();
+ policyList = new LinkedList<>();
}
else {
pdpSubGroupMap = pdpGroupMap.get(pdpGroup);
if (pdpSubGroupMap.get(pdpSubGroup) == null) {
}
else {
pdpSubGroupMap = pdpGroupMap.get(pdpGroup);
if (pdpSubGroupMap.get(pdpSubGroup) == null) {
- policyList = new LinkedList<JsonObject>();
+ policyList = new LinkedList<>();
}
else {
policyList = (List<JsonObject>) pdpSubGroupMap.get(pdpSubGroup);
}
else {
policyList = (List<JsonObject>) pdpSubGroupMap.get(pdpSubGroup);
}
private static JsonObject generateActivatePdpGroupPayload(
}
private static JsonObject generateActivatePdpGroupPayload(
- HashMap<String, HashMap<String, List<JsonObject>>> pdpGroupMap) {
+ Map<String, Map<String, List<JsonObject>>> pdpGroupMap) {
JsonArray payloadArray = new JsonArray();
JsonArray payloadArray = new JsonArray();
- for (Entry<String, HashMap<String, List<JsonObject>>> pdpGroupInfo : pdpGroupMap.entrySet()) {
+ for (Entry<String, Map<String, List<JsonObject>>> pdpGroupInfo : pdpGroupMap.entrySet()) {
JsonObject pdpGroupNode = new JsonObject();
JsonArray subPdpArray = new JsonArray();
pdpGroupNode.addProperty("name", pdpGroupInfo.getKey());
pdpGroupNode.add("deploymentSubgroups", subPdpArray);
JsonObject pdpGroupNode = new JsonObject();
JsonArray subPdpArray = new JsonArray();
pdpGroupNode.addProperty("name", pdpGroupInfo.getKey());
pdpGroupNode.add("deploymentSubgroups", subPdpArray);
- JsonObject pdpSubGroupNode = new JsonObject();
- subPdpArray.add(pdpSubGroupNode);
-
for (Entry<String, List<JsonObject>> pdpSubGroupInfo : pdpGroupInfo.getValue().entrySet()) {
for (Entry<String, List<JsonObject>> pdpSubGroupInfo : pdpGroupInfo.getValue().entrySet()) {
+ JsonObject pdpSubGroupNode = new JsonObject();
+ subPdpArray.add(pdpSubGroupNode);
pdpSubGroupNode.addProperty("pdpType", pdpSubGroupInfo.getKey());
pdpSubGroupNode.addProperty("action", "POST");
pdpSubGroupNode.addProperty("pdpType", pdpSubGroupInfo.getKey());
pdpSubGroupNode.addProperty("action", "POST");
for (MicroServicePolicy microServicePolicy : loop.getMicroServicePolicies()) {
policyNamesList.add(microServicePolicy.getName());
}
for (MicroServicePolicy microServicePolicy : loop.getMicroServicePolicies()) {
policyNamesList.add(microServicePolicy.getName());
}
+ logger.info("Policies that will be removed from PDP: " + policyNamesList);
return policyNamesList;
}
return policyNamesList;
}
new Gson().fromJson("{\"configtype\":\"json\"}", JsonObject.class), null, "pdpGroup1", "pdpSubgroup1");
loopTest.addMicroServicePolicy(microServicePolicy);
new Gson().fromJson("{\"configtype\":\"json\"}", JsonObject.class), null, "pdpGroup1", "pdpSubgroup1");
loopTest.addMicroServicePolicy(microServicePolicy);
+ MicroServicePolicy microServicePolicy2 = new MicroServicePolicy("configPolicyTest2", policyModel1, true,
+ new Gson().fromJson("{\"configtype\":\"json\"}", JsonObject.class), null, "pdpGroup2", "pdpSubgroup1");
+ loopTest.addMicroServicePolicy(microServicePolicy2);
+
PolicyModel policyModel2 = new PolicyModel("onap.policies.controlloop.Operational", null, "1.0.0");
OperationalPolicy opPolicy =
new OperationalPolicy("opPolicy", new Gson().fromJson("{\"configtype\":\"json\"}", JsonObject.class),
PolicyModel policyModel2 = new PolicyModel("onap.policies.controlloop.Operational", null, "1.0.0");
OperationalPolicy opPolicy =
new OperationalPolicy("opPolicy", new Gson().fromJson("{\"configtype\":\"json\"}", JsonObject.class),
String expectedRes = ResourceFileUtil.getResourceAsString("tosca/pdp-group-policy-payload.json");
assertThat(payload).isEqualTo(expectedRes);
String expectedRes = ResourceFileUtil.getResourceAsString("tosca/pdp-group-policy-payload.json");
assertThat(payload).isEqualTo(expectedRes);
+
+ assertThat(PolicyComponent.listPolicyNamesPdpGroup(loopTest)).containsExactlyInAnyOrder("opPolicy","configPolicyTest","configPolicyTest2");
+ },
+ {
+ "pdpType": "pdpSubgroup1",
+ "action": "POST",
+ "policies": [
+ {
+ "name": "configPolicyTest2",
+ "version": "1.0.0"
+ }
+ ]