--- /dev/null
+/*-
+ * ============LICENSE_START=======================================================
+ * 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.
+ * You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ *
+ * SPDX-License-Identifier: Apache-2.0
+ * ============LICENSE_END=========================================================
+ */
+
+package org.onap.policy.clamp.controlloop.participant.policy.client;
+
+import com.google.gson.JsonArray;
+import com.google.gson.JsonObject;
+import javax.ws.rs.client.Entity;
+import javax.ws.rs.core.MediaType;
+import javax.ws.rs.core.Response;
+import org.onap.policy.clamp.controlloop.participant.policy.main.parameters.ParticipantPolicyParameters;
+import org.springframework.stereotype.Component;
+
+@Component
+public class PolicyPapHttpClient extends AbstractHttpClient {
+
+ private static final String PAP_URI = "/policy/pap/v1/";
+ private final String pdpGroup;
+ private final String pdpType;
+
+ /**
+ * Constructor.
+ *
+ * @param parameters the policy participant parameters
+ */
+ public PolicyPapHttpClient(ParticipantPolicyParameters parameters) {
+ super(parameters.getPolicyPapParameters());
+ this.pdpGroup = parameters.getPdpGroup();
+ this.pdpType = parameters.getPdpType();
+ }
+
+ /**
+ * Deploy or undeploy Policies.
+ *
+ * @param policyName the name of the policy to be deployed/undeployed
+ * @param policyVersion the version of the policy to be deployed/undeployed
+ * @param action the action to deploy/undeploy policy
+ * @return Response
+ */
+ public Response handlePolicyDeployOrUndeploy(final String policyName, final String policyVersion,
+ final String action) {
+ // policies
+ JsonObject policyArrayBody = new JsonObject();
+ policyArrayBody.addProperty("name", policyName);
+ policyArrayBody.addProperty("version", policyVersion);
+ JsonArray policyArr = new JsonArray();
+ policyArr.add(policyArrayBody);
+
+ // deploymentSubgroups
+ JsonObject deploymentSubGrpBody = new JsonObject();
+ deploymentSubGrpBody.addProperty("pdpType", pdpType);
+ deploymentSubGrpBody.addProperty("action", action);
+ deploymentSubGrpBody.add("policies", policyArr);
+ JsonArray deployArr = new JsonArray();
+ deployArr.add(deploymentSubGrpBody);
+
+ // groups
+ JsonObject groupArrayBody = new JsonObject();
+ groupArrayBody.addProperty("name", pdpGroup);
+ groupArrayBody.add("deploymentSubgroups", deployArr);
+ JsonArray groupArr = new JsonArray();
+ groupArr.add(groupArrayBody);
+
+ // main json
+ JsonObject mainJson = new JsonObject();
+ mainJson.add("groups", groupArr);
+
+ return executePost(PAP_URI + "pdps/deployments/batch", Entity.entity(mainJson, MediaType.APPLICATION_JSON));
+ }
+}
import org.onap.policy.clamp.controlloop.participant.intermediary.api.ControlLoopElementListener;
import org.onap.policy.clamp.controlloop.participant.intermediary.api.ParticipantIntermediaryApi;
import org.onap.policy.clamp.controlloop.participant.policy.client.PolicyApiHttpClient;
+import org.onap.policy.clamp.controlloop.participant.policy.client.PolicyPapHttpClient;
import org.onap.policy.models.base.PfModelException;
import org.onap.policy.models.base.PfModelRuntimeException;
import org.onap.policy.models.tosca.authorative.concepts.ToscaConceptIdentifier;
private final Map<String, String> policyMap = new LinkedHashMap<>();
private final PolicyApiHttpClient apiHttpClient;
+ private final PolicyPapHttpClient papHttpClient;
@Setter
private ParticipantIntermediaryApi intermediaryApi;
* constructor.
*
* @param apiHttpClient the Policy Api Http Client
+ * @param papHttpClient the Policy Pap Http Client
*/
- public ControlLoopElementHandler(PolicyApiHttpClient apiHttpClient) {
+ public ControlLoopElementHandler(PolicyApiHttpClient apiHttpClient, PolicyPapHttpClient papHttpClient) {
+ this.papHttpClient = papHttpClient;
this.apiHttpClient = apiHttpClient;
}
/**
* Callback method to handle a control loop element state change.
*
+ * @param controlLoopId the ID of the control loop
* @param controlLoopElementId the ID of the control loop element
* @param currentState the current state of the control loop element
* @param orderedState the state to which the control loop element is changing to
}
break;
case PASSIVE:
+ try {
+ undeployPolicies(controlLoopElementId, orderedState);
+ } catch (PfModelRuntimeException e) {
+ LOGGER.debug("Undeploying policies failed - no policies to undeploy {}", controlLoopElementId);
+ }
intermediaryApi.updateControlLoopElementState(controlLoopId,
- controlLoopElementId, orderedState, ControlLoopState.PASSIVE,
- ParticipantMessageType.CONTROL_LOOP_STATE_CHANGE);
+ controlLoopElementId, orderedState, ControlLoopState.PASSIVE,
+ ParticipantMessageType.CONTROL_LOOP_STATE_CHANGE);
break;
case RUNNING:
- intermediaryApi.updateControlLoopElementState(controlLoopId,
- controlLoopElementId, orderedState, ControlLoopState.RUNNING,
- ParticipantMessageType.CONTROL_LOOP_STATE_CHANGE);
+ try {
+ deployPolicies(controlLoopId, controlLoopElementId, orderedState);
+ } catch (PfModelRuntimeException e) {
+ LOGGER.debug("Deploying policies failed {}", controlLoopElementId);
+ }
break;
default:
LOGGER.debug("Unknown orderedstate {}", orderedState);
}
private void deletePolicyData(ToscaConceptIdentifier controlLoopId,
- UUID controlLoopElementId, ControlLoopOrderedState newState) {
+ UUID controlLoopElementId, ControlLoopOrderedState newState) {
// Delete all policies of this controlLoop from policy framework
for (Entry<String, String> policy : policyMap.entrySet()) {
apiHttpClient.deletePolicy(policy.getKey(), policy.getValue());
}
policyTypeMap.clear();
intermediaryApi.updateControlLoopElementState(controlLoopId,
- controlLoopElementId, newState, ControlLoopState.UNINITIALISED,
- ParticipantMessageType.CONTROL_LOOP_STATE_CHANGE);
+ controlLoopElementId, newState, ControlLoopState.UNINITIALISED,
+ ParticipantMessageType.CONTROL_LOOP_STATE_CHANGE);
+ }
+
+ private void deployPolicies(ToscaConceptIdentifier controlLoopId, UUID controlLoopElementId,
+ ControlLoopOrderedState newState) {
+ // Deploy all policies of this controlLoop from Policy Framework
+ if (policyMap.entrySet() != null) {
+ for (Entry<String, String> policy : policyMap.entrySet()) {
+ papHttpClient.handlePolicyDeployOrUndeploy(policy.getKey(), policy.getValue(), "POST");
+ }
+ LOGGER.debug("Policies deployed to {} successfully", controlLoopElementId);
+ } else {
+ LOGGER.debug("No policies to deploy to {}", controlLoopElementId);
+ }
+ intermediaryApi.updateControlLoopElementState(controlLoopId,
+ controlLoopElementId, newState, ControlLoopState.RUNNING,
+ ParticipantMessageType.CONTROL_LOOP_STATE_CHANGE);
+ }
+
+ private void undeployPolicies(UUID controlLoopElementId, ControlLoopOrderedState newState) {
+ // Undeploy all policies of this controlloop from Policy Framework
+ if (policyMap.entrySet() != null) {
+ for (Entry<String, String> policy : policyMap.entrySet()) {
+ papHttpClient.handlePolicyDeployOrUndeploy(policy.getKey(), policy.getValue(), "DELETE");
+ }
+ LOGGER.debug("Undeployed policies from {} successfully", controlLoopElementId);
+ } else {
+ LOGGER.debug("No policies are deployed to {}", controlLoopElementId);
+ }
}
/**
*/
@Override
public void controlLoopElementUpdate(ToscaConceptIdentifier controlLoopId, ControlLoopElement element,
- ToscaNodeTemplate clElementDefinition)
+ ToscaNodeTemplate clElementDefinition)
throws PfModelException {
intermediaryApi.updateControlLoopElementState(controlLoopId, element.getId(), element.getOrderedState(),
ControlLoopState.PASSIVE, ParticipantMessageType.CONTROL_LOOP_UPDATE);
intermediaryApi.updateControlLoopElementStatistics(controlLoopElementId, clElementStatistics);
}
}
-}
+}
\ No newline at end of file
Code Review / policy / clamp.git / commitdiff