8b7876c71855fa746d19500c34f4a9b7b7e24c4b
[policy/drools-applications.git] /
1 /*-
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
8  *
9  *      http://www.apache.org/licenses/LICENSE-2.0
10  *
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=========================================================
17  */
18
19 package org.onap.policy.controlloop.utils;
20
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;
30
31 /**
32  * Control Loop Utils.
33  */
34 public class ControlLoopUtils {
35
36     public static final Logger logger = LoggerFactory.getLogger(ControlLoopUtils.class);
37     public static final String TOSCA_POLICY_PROPERTY_CONTENT = "content";
38
39     /**
40      * Get a Control Loop Parameters object from a Tosca Policy.
41      */
42     public static ControlLoopParams toControlLoopParams(ToscaPolicy policy) {
43
44         // TODO: ControlLoopParams class should be moved to this repo and take Tosca Policy in a constructor.
45
46         /* No exceptions are thrown to keep the DRL simpler */
47
48         try {
49             if (policy == null || policy.getProperties() == null
50                 || policy.getProperties().get(TOSCA_POLICY_PROPERTY_CONTENT) == null) {
51                 logger.error("Invalid Policy: {}", policy);
52                 return null;
53             }
54
55             String encodedPolicy = policy.getProperties().get(TOSCA_POLICY_PROPERTY_CONTENT).toString();
56             String decodedPolicy = URLDecoder.decode(encodedPolicy, "UTF-8");
57
58             ControlLoopProcessor controlLoopProcessor = new ControlLoopProcessor(decodedPolicy);
59             if (controlLoopProcessor.getControlLoop() == null
60                 || StringUtils.isEmpty(controlLoopProcessor.getControlLoop().getControlLoopName())) {
61                 return null;
62             }
63
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());
70
71             return controlLoopParams;
72         } catch (ControlLoopException | RuntimeException | UnsupportedEncodingException e) {
73             logger.error("Invalid Policy because of {}: {}", e.getMessage(), policy, e);
74             return null;
75         }
76     }
77
78 }