2 * ============LICENSE_START=======================================================
3 * Copyright (C) 2019 AT&T Intellectual Property. All rights reserved.
4 * ================================================================================
5 * Licensed under the Apache License, Version 2.0 (the "License");
6 * you may not use this file except in compliance with the License.
7 * You may obtain a copy of the License at
9 * http://www.apache.org/licenses/LICENSE-2.0
11 * Unless required by applicable law or agreed to in writing, software
12 * distributed under the License is distributed on an "AS IS" BASIS,
13 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
14 * See the License for the specific language governing permissions and
15 * limitations under the License.
16 * ============LICENSE_END=========================================================
19 package org.onap.policy.controlloop.utils;
21 import java.io.UnsupportedEncodingException;
22 import java.net.URLDecoder;
23 import org.apache.commons.lang3.StringUtils;
24 import org.onap.policy.controlloop.ControlLoopException;
25 import org.onap.policy.controlloop.params.ControlLoopParams;
26 import org.onap.policy.controlloop.processor.ControlLoopProcessor;
27 import org.onap.policy.models.tosca.authorative.concepts.ToscaPolicy;
28 import org.slf4j.Logger;
29 import org.slf4j.LoggerFactory;
34 public class ControlLoopUtils {
36 public static final Logger logger = LoggerFactory.getLogger(ControlLoopUtils.class);
37 public static final String TOSCA_POLICY_PROPERTY_CONTENT = "content";
40 * Get a Control Loop Parameters object from a Tosca Policy.
42 public static ControlLoopParams toControlLoopParams(ToscaPolicy policy) {
44 // TODO: ControlLoopParams class should be moved to this repo and take Tosca Policy in a constructor.
46 /* No exceptions are thrown to keep the DRL simpler */
49 if (policy == null || policy.getProperties() == null
50 || policy.getProperties().get(TOSCA_POLICY_PROPERTY_CONTENT) == null) {
51 logger.error("Invalid Policy: {}", policy);
55 String encodedPolicy = policy.getProperties().get(TOSCA_POLICY_PROPERTY_CONTENT).toString();
56 String decodedPolicy = URLDecoder.decode(encodedPolicy, "UTF-8");
58 ControlLoopProcessor controlLoopProcessor = new ControlLoopProcessor(decodedPolicy);
59 if (controlLoopProcessor.getControlLoop() == null
60 || StringUtils.isEmpty(controlLoopProcessor.getControlLoop().getControlLoopName())) {
64 ControlLoopParams controlLoopParams = new ControlLoopParams();
65 controlLoopParams.setClosedLoopControlName(controlLoopProcessor.getControlLoop().getControlLoopName());
66 controlLoopParams.setControlLoopYaml(encodedPolicy);
67 controlLoopParams.setPolicyScope(policy.getType() + ":" + policy.getTypeVersion());
68 controlLoopParams.setPolicyName(policy.getName());
69 controlLoopParams.setPolicyVersion(policy.getVersion());
71 return controlLoopParams;
72 } catch (ControlLoopException | RuntimeException | UnsupportedEncodingException e) {
73 logger.error("Invalid Policy because of {}: {}", e.getMessage(), policy, e);