2 * ============LICENSE_START=======================================================
4 * ================================================================================
5 * Copyright (C) 2017, 2019 AT&T Intellectual Property. All rights reserved.
6 * Modified Copyright (C) 2018 Samsung Electronics Co., Ltd.
7 * Modifications Copyright (C) 2019 Bell Canada
8 * ================================================================================
9 * Licensed under the Apache License, Version 2.0 (the "License");
10 * you may not use this file except in compliance with the License.
11 * You may obtain a copy of the License at
13 * http://www.apache.org/licenses/LICENSE-2.0
15 * Unless required by applicable law or agreed to in writing, software
16 * distributed under the License is distributed on an "AS IS" BASIS,
17 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
18 * See the License for the specific language governing permissions and
19 * limitations under the License.
20 * ============LICENSE_END=========================================================
23 package org.onap.policy.admin;
25 import com.att.research.xacml.util.XACMLProperties;
27 import org.onap.policy.common.logging.flexlogger.FlexLogger;
28 import org.onap.policy.common.logging.flexlogger.Logger;
29 import org.onap.policy.controller.ActionPolicyController;
30 import org.onap.policy.controller.CreateBRMSParamController;
31 import org.onap.policy.controller.CreateBRMSRawController;
32 import org.onap.policy.controller.CreateClosedLoopFaultController;
33 import org.onap.policy.controller.CreateClosedLoopPMController;
34 import org.onap.policy.controller.CreateDcaeMicroServiceController;
35 import org.onap.policy.controller.CreateFirewallController;
36 import org.onap.policy.controller.CreateOptimizationController;
37 import org.onap.policy.controller.CreatePolicyController;
38 import org.onap.policy.controller.DecisionPolicyController;
39 import org.onap.policy.rest.adapter.PolicyRestAdapter;
40 import org.onap.policy.rest.jpa.PolicyEntity;
42 public class PolicyAdapter {
44 private static final Logger LOGGER = FlexLogger.getLogger(PolicyAdapter.class);
49 * @param policyAdapter PolicyRestAdapter object
50 * @param entity PolicyEntity object
52 public void configure(PolicyRestAdapter policyAdapter, PolicyEntity entity) {
53 String policyNameValue = policyAdapter.getPolicyName().substring(0, policyAdapter.getPolicyName().indexOf('_'));
54 String configPolicyName = getConfigPolicyName(policyAdapter);
55 policyAdapter.setPolicyType(policyNameValue);
57 if (configPolicyName != null) {
58 policyAdapter.setConfigPolicyType(configPolicyName);
60 if ("Action".equalsIgnoreCase(policyAdapter.getPolicyType())) {
61 new ActionPolicyController().prePopulateActionPolicyData(policyAdapter);
63 if ("Decision".equalsIgnoreCase(policyAdapter.getPolicyType())) {
64 new DecisionPolicyController().prePopulateDecisionPolicyData(policyAdapter, entity);
66 if ("Config".equalsIgnoreCase(policyAdapter.getPolicyType())) {
67 prePopulatePolicyData(policyAdapter, entity);
71 private String getConfigPolicyName(PolicyRestAdapter policyAdapter) {
72 String configPolicyName = null;
73 if (policyAdapter.getPolicyName().startsWith("Config_PM")) {
74 configPolicyName = "ClosedLoop_PM";
75 } else if (policyAdapter.getPolicyName().startsWith("Config_Fault")) {
76 configPolicyName = "ClosedLoop_Fault";
77 } else if (policyAdapter.getPolicyName().startsWith("Config_FW")) {
78 configPolicyName = "Firewall Config";
79 } else if (policyAdapter.getPolicyName().startsWith("Config_BRMS_Raw")) {
80 configPolicyName = "BRMS_Raw";
81 } else if (policyAdapter.getPolicyName().startsWith("Config_BRMS_Param")) {
82 configPolicyName = "BRMS_Param";
83 } else if (policyAdapter.getPolicyName().startsWith("Config_MS")) {
84 configPolicyName = "Micro Service";
85 } else if (policyAdapter.getPolicyName().startsWith("Config_OOF")) {
86 configPolicyName = "Optimization";
87 } else if (policyAdapter.getPolicyName().startsWith("Action")
88 || policyAdapter.getPolicyName().startsWith("Decision")) {
89 // No configPolicyName is applicable
91 configPolicyName = "Base";
93 return configPolicyName;
96 private void prePopulatePolicyData(PolicyRestAdapter policyAdapter, PolicyEntity entity) {
97 if ("Base".equalsIgnoreCase(policyAdapter.getConfigPolicyType())) {
98 new CreatePolicyController().prePopulateBaseConfigPolicyData(policyAdapter, entity);
99 } else if ("BRMS_Raw".equalsIgnoreCase(policyAdapter.getConfigPolicyType())) {
100 new CreateBRMSRawController().prePopulateBRMSRawPolicyData(policyAdapter, entity);
101 } else if ("BRMS_Param".equalsIgnoreCase(policyAdapter.getConfigPolicyType())) {
102 new CreateBRMSParamController().prePopulateBRMSParamPolicyData(policyAdapter, entity);
103 } else if ("ClosedLoop_Fault".equalsIgnoreCase(policyAdapter.getConfigPolicyType())) {
104 new CreateClosedLoopFaultController().prePopulateClosedLoopFaultPolicyData(policyAdapter, entity);
105 } else if ("ClosedLoop_PM".equalsIgnoreCase(policyAdapter.getConfigPolicyType())) {
106 new CreateClosedLoopPMController().prePopulateClosedLoopPMPolicyData(policyAdapter, entity);
107 } else if ("Micro Service".equalsIgnoreCase(policyAdapter.getConfigPolicyType())) {
108 new CreateDcaeMicroServiceController().prePopulateDCAEMSPolicyData(policyAdapter, entity);
109 } else if ("Optimization".equalsIgnoreCase(policyAdapter.getConfigPolicyType())) {
110 new CreateOptimizationController().prePopulatePolicyData(policyAdapter, entity);
111 } else if ("Firewall Config".equalsIgnoreCase(policyAdapter.getConfigPolicyType())) {
112 new CreateFirewallController().prePopulateFWPolicyData(policyAdapter, entity);
119 * @return Returns a PolicyAdapter instance
121 public static PolicyAdapter getInstance() {
123 Class<?> policyAdapter = Class.forName(
124 XACMLProperties.getProperty("policyAdapter.impl.className", PolicyAdapter.class.getName()));
125 return (PolicyAdapter) policyAdapter.newInstance();
126 } catch (ClassNotFoundException | InstantiationException | IllegalAccessException
127 | IllegalArgumentException e) {
128 LOGGER.error("Exception Occurred" + e);