2 * ============LICENSE_START=======================================================
4 * ================================================================================
5 * Copyright (C) 2017 AT&T Intellectual Property. All rights reserved.
6 * ================================================================================
7 * Licensed under the Apache License, Version 2.0 (the "License");
8 * you may not use this file except in compliance with the License.
9 * You may obtain a copy of the License at
11 * http://www.apache.org/licenses/LICENSE-2.0
13 * Unless required by applicable law or agreed to in writing, software
14 * distributed under the License is distributed on an "AS IS" BASIS,
15 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
16 * See the License for the specific language governing permissions and
17 * limitations under the License.
18 * ============LICENSE_END=========================================================
21 package org.openecomp.policy.controller;
24 import java.io.IOException;
25 import java.util.Iterator;
26 import java.util.LinkedHashMap;
27 import java.util.List;
29 import javax.json.JsonArray;
30 import javax.json.JsonObject;
32 import org.openecomp.policy.admin.PolicyManagerServlet;
33 import org.openecomp.policy.common.logging.flexlogger.FlexLogger;
34 import org.openecomp.policy.common.logging.flexlogger.Logger;
35 import org.openecomp.policy.rest.adapter.ClosedLoopPMBody;
36 import org.openecomp.policy.rest.adapter.PolicyRestAdapter;
37 import org.openecomp.policy.rest.jpa.PolicyEntity;
39 import com.fasterxml.jackson.databind.ObjectMapper;
41 import oasis.names.tc.xacml._3_0.core.schema.wd_17.AllOfType;
42 import oasis.names.tc.xacml._3_0.core.schema.wd_17.AnyOfType;
43 import oasis.names.tc.xacml._3_0.core.schema.wd_17.AttributeDesignatorType;
44 import oasis.names.tc.xacml._3_0.core.schema.wd_17.AttributeValueType;
45 import oasis.names.tc.xacml._3_0.core.schema.wd_17.MatchType;
46 import oasis.names.tc.xacml._3_0.core.schema.wd_17.PolicyType;
47 import oasis.names.tc.xacml._3_0.core.schema.wd_17.TargetType;
49 public class CreateClosedLoopPMController{
51 private static final Logger LOGGER = FlexLogger.getLogger(CreateClosedLoopPMController.class);
53 protected PolicyRestAdapter policyAdapter = null;
55 public void prePopulateClosedLoopPMPolicyData(PolicyRestAdapter policyAdapter, PolicyEntity entity) {
56 if (policyAdapter.getPolicyData() instanceof PolicyType) {
57 Object policyData = policyAdapter.getPolicyData();
58 PolicyType policy = (PolicyType) policyData;
59 policyAdapter.setOldPolicyFileName(policyAdapter.getPolicyName());
60 String policyNameValue = policyAdapter.getPolicyName().substring(policyAdapter.getPolicyName().indexOf("PM_") +3);
61 policyAdapter.setPolicyName(policyNameValue);
62 String description = "";
64 description = policy.getDescription().substring(0, policy.getDescription().indexOf("@CreatedBy:"));
66 LOGGER.info("General error" , e);
67 description = policy.getDescription();
69 policyAdapter.setPolicyDescription(description);
70 // Get the target data under policy.
71 TargetType target = policy.getTarget();
73 // Under target we have AnyOFType
74 List<AnyOfType> anyOfList = target.getAnyOf();
75 if (anyOfList != null) {
76 Iterator<AnyOfType> iterAnyOf = anyOfList.iterator();
77 while (iterAnyOf.hasNext()) {
78 AnyOfType anyOf = iterAnyOf.next();
79 // Under AnyOFType we have AllOFType
80 List<AllOfType> allOfList = anyOf.getAllOf();
81 if (allOfList != null) {
82 Iterator<AllOfType> iterAllOf = allOfList.iterator();
83 while (iterAllOf.hasNext()) {
84 AllOfType allOf = iterAllOf.next();
85 // Under AllOFType we have Match
86 List<MatchType> matchList = allOf.getMatch();
87 if (matchList != null) {
88 Iterator<MatchType> iterMatch = matchList.iterator();
89 while (matchList.size()>1 && iterMatch.hasNext()) {
90 MatchType match = iterMatch.next();
92 // Under the match we have attribute value and
93 // attributeDesignator. So,finally down to the actual attribute.
95 AttributeValueType attributeValue = match.getAttributeValue();
96 String value = (String) attributeValue.getContent().get(0);
97 AttributeDesignatorType designator = match.getAttributeDesignator();
98 String attributeId = designator.getAttributeId();
100 // First match in the target is EcompName, so set that value.
101 if (attributeId.equals("ECOMPName")) {
102 policyAdapter.setEcompName(value);
104 if (attributeId.equals("RiskType")){
105 policyAdapter.setRiskType(value);
107 if (attributeId.equals("RiskLevel")){
108 policyAdapter.setRiskLevel(value);
110 if (attributeId.equals("guard")){
111 policyAdapter.setGuard(value);
113 if (attributeId.equals("TTLDate") && !value.contains("NA")){
114 String newDate = convertDate(value, true);
115 policyAdapter.setTtlDate(newDate);
117 if (attributeId.equals("ServiceType")){
118 LinkedHashMap<String, String> serviceTypePolicyName1 = new LinkedHashMap<>();
119 String key = "serviceTypePolicyName";
120 serviceTypePolicyName1.put(key, value);
121 policyAdapter.setServiceTypePolicyName(serviceTypePolicyName1);
122 LinkedHashMap<String, String> vertica = new LinkedHashMap<>();
123 vertica.put("verticaMetrics", getVertica(value));
124 policyAdapter.setVerticaMetrics(vertica);
125 LinkedHashMap<String, String> desc = new LinkedHashMap<>();
126 desc.put("policyDescription", getDescription(value));
127 policyAdapter.setDescription(desc);
128 LinkedHashMap<String, Object> attributes = new LinkedHashMap<>();
129 attributes.put("attributes", getAttributes(value));
130 policyAdapter.setAttributeFields(attributes);
139 readClosedLoopJSONFile(policyAdapter, entity);
143 private String convertDate(String dateTTL, boolean portalType) {
144 String formateDate = null;
149 parts = dateTTL.split("-");
150 formateDate = parts[2] + "-" + parts[1] + "-" + parts[0] + "T05:00:00.000Z";
152 date = dateTTL.split("T");
153 parts = date[0].split("-");
154 formateDate = parts[2] + "-" + parts[1] + "-" + parts[0];
159 protected void readClosedLoopJSONFile(PolicyRestAdapter policyAdapter, PolicyEntity entity) {
160 ObjectMapper mapper = new ObjectMapper();
162 ClosedLoopPMBody closedLoopBody = mapper.readValue(entity.getConfigurationData().getConfigBody(), ClosedLoopPMBody.class);
163 policyAdapter.setJsonBodyData(closedLoopBody);
164 } catch (IOException e) {
165 LOGGER.error("Exception Occured"+e);
169 //get vertica metrics data from the table
170 private String getVertica(String policyName){
171 String verticas = null;
172 JsonArray data = PolicyManagerServlet.getPolicyNames();
173 for(int i=0 ; i< data.size(); i++){
174 if(policyName.equals(data.getJsonObject(i).getJsonString("serviceTypePolicyName").getString())){
175 verticas = data.getJsonObject(i).getJsonString("verticaMetrics").getString();
182 //get policy description from the table
183 private String getDescription(String policyName){
184 String description = null;
185 JsonArray data = PolicyManagerServlet.getPolicyNames();
186 for(int i=0 ; i< data.size(); i++){
187 if(policyName.equals(data.getJsonObject(i).getJsonString("serviceTypePolicyName").getString())){
188 description = data.getJsonObject(i).getJsonString("policyDescription").getString();
196 private JsonObject getAttributes(String policyName){
197 JsonObject attributes = null;
198 JsonArray data = PolicyManagerServlet.getPolicyNames();
199 for(int i=0 ; i< data.size(); i++){
200 if(policyName.equals(data.getJsonObject(i).getJsonString("serviceTypePolicyName").getString())){
201 attributes = data.getJsonObject(i).getJsonObject("attributes");