aboutsummaryrefslogtreecommitdiffstats
path: root/main/src/main/java/org/onap/policy/pap/main/rest/SessionData.java
diff options
context:
space:
mode:
Diffstat (limited to 'main/src/main/java/org/onap/policy/pap/main/rest/SessionData.java')
-rw-r--r--main/src/main/java/org/onap/policy/pap/main/rest/SessionData.java42
1 files changed, 21 insertions, 21 deletions
diff --git a/main/src/main/java/org/onap/policy/pap/main/rest/SessionData.java b/main/src/main/java/org/onap/policy/pap/main/rest/SessionData.java
index 0d8f7033..cdcc51c6 100644
--- a/main/src/main/java/org/onap/policy/pap/main/rest/SessionData.java
+++ b/main/src/main/java/org/onap/policy/pap/main/rest/SessionData.java
@@ -3,6 +3,7 @@
* ONAP PAP
* ================================================================================
* Copyright (C) 2019-2020 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.
@@ -37,13 +38,12 @@ import org.onap.policy.models.pdp.concepts.PdpStateChange;
import org.onap.policy.models.pdp.concepts.PdpUpdate;
import org.onap.policy.models.pdp.enums.PdpState;
import org.onap.policy.models.provider.PolicyModelsProvider;
+import org.onap.policy.models.tosca.authorative.concepts.ToscaConceptIdentifier;
+import org.onap.policy.models.tosca.authorative.concepts.ToscaConceptIdentifierOptVersion;
import org.onap.policy.models.tosca.authorative.concepts.ToscaPolicy;
import org.onap.policy.models.tosca.authorative.concepts.ToscaPolicyFilter;
import org.onap.policy.models.tosca.authorative.concepts.ToscaPolicyFilter.ToscaPolicyFilterBuilder;
-import org.onap.policy.models.tosca.authorative.concepts.ToscaPolicyIdentifier;
-import org.onap.policy.models.tosca.authorative.concepts.ToscaPolicyIdentifierOptVersion;
import org.onap.policy.models.tosca.authorative.concepts.ToscaPolicyType;
-import org.onap.policy.models.tosca.authorative.concepts.ToscaPolicyTypeIdentifier;
import org.onap.policy.pap.main.notification.PolicyPdpNotificationData;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
@@ -75,7 +75,7 @@ public class SessionData {
* Maps a policy type to the list of matching groups. Every group appearing within
* this map has a corresponding entry in {@link #groupCache}.
*/
- private final Map<ToscaPolicyTypeIdentifier, List<GroupData>> type2groups = new HashMap<>();
+ private final Map<ToscaConceptIdentifier, List<GroupData>> type2groups = new HashMap<>();
/**
* Maps a PDP name to its most recently generated update and state-change requests.
@@ -85,24 +85,24 @@ public class SessionData {
/**
* Maps a policy's identifier to the policy.
*/
- private final Map<ToscaPolicyIdentifierOptVersion, ToscaPolicy> policyCache = new HashMap<>();
+ private final Map<ToscaConceptIdentifierOptVersion, ToscaPolicy> policyCache = new HashMap<>();
/**
* Maps a policy type's identifier to the policy.
*/
- private final Map<ToscaPolicyTypeIdentifier, ToscaPolicyType> typeCache = new HashMap<>();
+ private final Map<ToscaConceptIdentifier, ToscaPolicyType> typeCache = new HashMap<>();
/**
* Policies to be deployed. This is just used to build up the data, which is then
* passed to the notifier once the update is "committed".
*/
- private final Map<ToscaPolicyIdentifier, PolicyPdpNotificationData> deploy = new HashMap<>();
+ private final Map<ToscaConceptIdentifier, PolicyPdpNotificationData> deploy = new HashMap<>();
/**
* Policies to be undeployed. This is just used to build up the data, which is then
* passed to the notifier once the update is "committed".
*/
- private final Map<ToscaPolicyIdentifier, PolicyPdpNotificationData> undeploy = new HashMap<>();
+ private final Map<ToscaConceptIdentifier, PolicyPdpNotificationData> undeploy = new HashMap<>();
/**
@@ -122,7 +122,7 @@ public class SessionData {
* @return the specified policy type
* @throws PfModelException if an error occurred
*/
- public ToscaPolicyType getPolicyType(ToscaPolicyTypeIdentifier desiredType) throws PfModelException {
+ public ToscaPolicyType getPolicyType(ToscaConceptIdentifier desiredType) throws PfModelException {
ToscaPolicyType type = typeCache.get(desiredType);
if (type == null) {
@@ -147,7 +147,7 @@ public class SessionData {
* @return the specified policy
* @throws PfModelException if an error occurred
*/
- public ToscaPolicy getPolicy(ToscaPolicyIdentifierOptVersion desiredPolicy) throws PfModelException {
+ public ToscaPolicy getPolicy(ToscaConceptIdentifierOptVersion desiredPolicy) throws PfModelException {
ToscaPolicy policy = policyCache.get(desiredPolicy);
if (policy == null) {
@@ -164,7 +164,7 @@ public class SessionData {
}
// desired version may have only been a prefix - cache with full identifier, too
- policyCache.putIfAbsent(new ToscaPolicyIdentifierOptVersion(policy.getIdentifier()), policy);
+ policyCache.putIfAbsent(new ToscaConceptIdentifierOptVersion(policy.getIdentifier()), policy);
return policy;
}
@@ -346,7 +346,7 @@ public class SessionData {
* @return the active groups supporting the given policy
* @throws PfModelException if an error occurred
*/
- public List<PdpGroup> getActivePdpGroupsByPolicyType(ToscaPolicyTypeIdentifier type) throws PfModelException {
+ public List<PdpGroup> getActivePdpGroupsByPolicyType(ToscaConceptIdentifier type) throws PfModelException {
/*
* Cannot use computeIfAbsent() because the enclosed code throws an unchecked
* exception and handling that would obfuscate the code too much, thus disabling
@@ -431,7 +431,7 @@ public class SessionData {
* @param pdps PDPs to which the policy is being deployed
* @throws PfModelException if an error occurred
*/
- protected void trackDeploy(ToscaPolicyIdentifier policyId, Collection<String> pdps) throws PfModelException {
+ protected void trackDeploy(ToscaConceptIdentifier policyId, Collection<String> pdps) throws PfModelException {
trackDeploy(policyId, new HashSet<>(pdps));
}
@@ -442,7 +442,7 @@ public class SessionData {
* @param pdps PDPs to which the policy is being deployed
* @throws PfModelException if an error occurred
*/
- protected void trackDeploy(ToscaPolicyIdentifier policyId, Set<String> pdps) throws PfModelException {
+ protected void trackDeploy(ToscaConceptIdentifier policyId, Set<String> pdps) throws PfModelException {
addData(policyId, pdps, deploy, undeploy);
}
@@ -453,7 +453,7 @@ public class SessionData {
* @param pdps PDPs to which the policy is being undeployed
* @throws PfModelException if an error occurred
*/
- protected void trackUndeploy(ToscaPolicyIdentifier policyId, Collection<String> pdps) throws PfModelException {
+ protected void trackUndeploy(ToscaConceptIdentifier policyId, Collection<String> pdps) throws PfModelException {
trackUndeploy(policyId, new HashSet<>(pdps));
}
@@ -464,7 +464,7 @@ public class SessionData {
* @param pdps PDPs to which the policy is being undeployed
* @throws PfModelException if an error occurred
*/
- protected void trackUndeploy(ToscaPolicyIdentifier policyId, Set<String> pdps) throws PfModelException {
+ protected void trackUndeploy(ToscaConceptIdentifier policyId, Set<String> pdps) throws PfModelException {
addData(policyId, pdps, undeploy, deploy);
}
@@ -477,17 +477,17 @@ public class SessionData {
* @param removeMap map from which it should be removed
* @throws PfModelException if an error occurred
*/
- private void addData(ToscaPolicyIdentifier policyId, Set<String> pdps,
- Map<ToscaPolicyIdentifier, PolicyPdpNotificationData> addMap,
- Map<ToscaPolicyIdentifier, PolicyPdpNotificationData> removeMap) throws PfModelException {
+ private void addData(ToscaConceptIdentifier policyId, Set<String> pdps,
+ Map<ToscaConceptIdentifier, PolicyPdpNotificationData> addMap,
+ Map<ToscaConceptIdentifier, PolicyPdpNotificationData> removeMap) throws PfModelException {
PolicyPdpNotificationData removeData = removeMap.get(policyId);
if (removeData != null) {
removeData.removeAll(pdps);
}
- ToscaPolicyIdentifierOptVersion optid = new ToscaPolicyIdentifierOptVersion(policyId);
- ToscaPolicyTypeIdentifier policyType = getPolicy(optid).getTypeIdentifier();
+ ToscaConceptIdentifierOptVersion optid = new ToscaConceptIdentifierOptVersion(policyId);
+ ToscaConceptIdentifier policyType = getPolicy(optid).getTypeIdentifier();
addMap.computeIfAbsent(policyId, key -> new PolicyPdpNotificationData(policyId, policyType)).addAll(pdps);
}