2 * ============LICENSE_START=======================================================
4 * ================================================================================
5 * Copyright (C) 2017-2019 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.onap.policy.pdp.rest.api.services;
23 import java.util.UUID;
24 import javax.json.JsonException;
25 import javax.json.JsonObject;
26 import org.onap.policy.api.DictionaryParameters;
27 import org.onap.policy.api.DictionaryResponse;
28 import org.onap.policy.api.PolicyException;
29 import org.onap.policy.common.logging.flexlogger.FlexLogger;
30 import org.onap.policy.common.logging.flexlogger.Logger;
31 import org.onap.policy.pdp.rest.api.utils.PolicyApiUtils;
32 import org.onap.policy.std.StdDictionaryResponse;
33 import org.onap.policy.xacml.api.XACMLErrorConstants;
34 import org.springframework.http.HttpStatus;
36 public class GetDictionaryService {
37 private static final Logger LOGGER = FlexLogger.getLogger(GetDictionaryService.class.getName());
39 private DictionaryResponse dictionaryResponse = null;
40 private HttpStatus status = HttpStatus.BAD_REQUEST;
41 private String message = null;
42 private DictionaryParameters dictionaryParameters = null;
44 public GetDictionaryService(DictionaryParameters dictionaryParameters, String requestID) {
45 this.dictionaryParameters = dictionaryParameters;
46 if (dictionaryParameters.getRequestID() == null) {
47 UUID requestUUID = null;
48 if (requestID != null && !requestID.isEmpty()) {
50 requestUUID = UUID.fromString(requestID);
51 } catch (IllegalArgumentException e) {
52 requestUUID = UUID.randomUUID();
53 LOGGER.info("Generated Random UUID: " + requestUUID.toString(), e);
56 requestUUID = UUID.randomUUID();
57 LOGGER.info("Generated Random UUID: " + requestUUID.toString());
59 this.dictionaryParameters.setRequestID(requestUUID);
64 } catch (PolicyException e) {
65 StdDictionaryResponse dictionaryResponse = new StdDictionaryResponse();
66 dictionaryResponse.setResponseMessage(XACMLErrorConstants.ERROR_DATA_ISSUE + e);
67 this.dictionaryResponse = dictionaryResponse;
68 status = HttpStatus.BAD_REQUEST;
72 private void specialCheck() {
73 if (dictionaryResponse != null && (dictionaryResponse.getResponseMessage() != null
74 && dictionaryResponse.getResponseMessage().contains("PE300"))) {
75 status = HttpStatus.BAD_REQUEST;
79 private void run() throws PolicyException {
81 if (!getValidation()) {
82 LOGGER.error(message);
83 throw new PolicyException(message);
87 status = HttpStatus.OK;
88 dictionaryResponse = processResult();
89 } catch (Exception e) {
90 LOGGER.error(XACMLErrorConstants.ERROR_DATA_ISSUE + e);
91 status = HttpStatus.BAD_REQUEST;
92 throw new PolicyException(e);
96 private DictionaryResponse processResult() throws PolicyException {
97 StdDictionaryResponse response = new StdDictionaryResponse();
98 PAPServices papServices = new PAPServices();
99 String result = (String) papServices.callPAP(null,
100 new String[] {"operation=get", "apiflag=api", "dictionaryType=" + dictionaryParameters.getDictionary()},
101 dictionaryParameters.getRequestID(), "dictionaryItem");
103 if (result != null && result.contains("data")) {
104 String jsonString = formatDictionaryJson(result);
105 String responseMessage = result.substring(0, 82);
106 JsonObject json = null;
108 json = PolicyApiUtils.stringToJsonObject(jsonString.replace("\\\\\\", "\\"));
109 String datas = json.getString("data").replaceFirst("\"\\[", "[");
110 int i = datas.lastIndexOf("]");
112 datas = new StringBuilder(datas).replace(i, i + 2, "]").toString();
114 json = PolicyApiUtils.stringToJsonObject(datas);
115 } catch (JsonException | IllegalStateException e) {
116 message = XACMLErrorConstants.ERROR_DATA_ISSUE + " improper Dictionary JSON object : "
117 + dictionaryParameters.getDictionaryJson();
118 LOGGER.error(message, e);
119 response.setResponseMessage(message);
120 response.setResponseCode(400);
123 response.setResponseCode(papServices.getResponseCode());
124 response.setDictionaryJson(json);
125 response.setResponseMessage(responseMessage);
127 response.setResponseCode(400);
128 response.setResponseMessage(result);
129 if (result != null && result.contains("PE200")) {
130 status = HttpStatus.INTERNAL_SERVER_ERROR;
132 status = HttpStatus.BAD_REQUEST;
138 private String formatDictionaryJson(String result) {
139 String jsonString = result.substring(82);
140 String dictionary = dictionaryParameters.getDictionary();
142 switch (dictionary) {
144 jsonString = jsonString.replace("onapNameDictionaryDatas", "DictionaryDatas");
147 jsonString = jsonString.replace("attributeDictionaryDatas", "DictionaryDatas");
150 jsonString = jsonString.replace("actionPolicyDictionaryDatas", "DictionaryDatas");
152 case "BRMSParamTemplate":
153 jsonString = jsonString.replace("brmsParamDictionaryDatas", "DictionaryDatas");
156 jsonString = jsonString.replace("vsclActionDictionaryDatas", "DictionaryDatas");
159 jsonString = jsonString.replace("vnfTypeDictionaryDatas", "DictionaryDatas");
162 jsonString = jsonString.replace("pepOptionsDictionaryDatas", "DictionaryDatas");
165 jsonString = jsonString.replace("varbindDictionaryDatas", "DictionaryDatas");
168 jsonString = jsonString.replace("closedLoopServiceDictionaryDatas", "DictionaryDatas");
171 jsonString = jsonString.replace("closedLoopSiteDictionaryDatas", "DictionaryDatas");
174 jsonString = jsonString.replace("settingsDictionaryDatas", "DictionaryDatas");
176 case "RainyDayTreatments":
177 jsonString = jsonString.replace("rainyDayDictionaryDatas", "DictionaryDatas");
179 case "DescriptiveScope":
180 jsonString = jsonString.replace("descriptiveScopeDictionaryDatas", "DictionaryDatas");
183 jsonString = jsonString.replace("enforcerDictionaryDatas", "DictionaryDatas");
186 jsonString = jsonString.replace("actionListDictionaryDatas", "DictionaryDatas");
189 jsonString = jsonString.replace("protocolListDictionaryDatas", "DictionaryDatas");
192 jsonString = jsonString.replace("zoneDictionaryDatas", "DictionaryDatas");
195 jsonString = jsonString.replace("securityZoneDictionaryDatas", "DictionaryDatas");
198 jsonString = jsonString.replace("prefixListDictionaryDatas", "DictionaryDatas");
201 jsonString = jsonString.replace("addressGroupDictionaryDatas", "DictionaryDatas");
204 jsonString = jsonString.replace("serviceGroupDictionaryDatas", "DictionaryDatas");
207 jsonString = jsonString.replace("serviceListDictionaryDatas", "DictionaryDatas");
211 case "FirewallRuleList":
213 jsonString = jsonString.replace("termListDictionaryDatas", "DictionaryDatas");
215 case "MicroServiceLocation":
216 jsonString = jsonString.replace("microServiceLocationDictionaryDatas", "DictionaryDatas");
218 case "MicroServiceConfigName":
219 jsonString = jsonString.replace("microServiceCongigNameDictionaryDatas", "DictionaryDatas");
221 case "MicroServiceDictionaryData":
222 jsonString = jsonString.replace("microServiceDictionaryDatas", "DictionaryDatas");
225 jsonString = jsonString.replace("dcaeUUIDDictionaryDatas", "DictionaryDatas");
227 case "MicroServiceModels":
228 jsonString = jsonString.replace("microServiceModelsDictionaryDatas", "DictionaryDatas");
230 case "OptimizationModels":
231 jsonString = jsonString.replace("optmizationModelsDictionaryDatas", "DictionaryDatas");
233 case "PolicyScopeService":
234 jsonString = jsonString.replace("psServiceDictionaryDatas", "DictionaryDatas");
236 case "PolicyScopeResource":
237 jsonString = jsonString.replace("psResourceDictionaryDatas", "DictionaryDatas");
239 case "PolicyScopeType":
240 jsonString = jsonString.replace("psTypeDictionaryDatas", "DictionaryDatas");
242 case "PolicyScopeClosedLoop":
243 jsonString = jsonString.replace("psClosedLoopDictionaryDatas", "DictionaryDatas");
245 case "GroupPolicyScopeList":
246 jsonString = jsonString.replace("groupPolicyScopeListDatas", "DictionaryDatas");
249 jsonString = jsonString.replace("riskTypeDictionaryDatas", "DictionaryDatas");
251 case "SafePolicyWarning":
252 jsonString = jsonString.replace("safePolicyWarningDatas", "DictionaryDatas");
254 case "MicroServiceDictionary":
255 jsonString = jsonString.replace("microServiceDictionaryDatas", "DictionaryDatas");
263 private boolean getValidation() {
264 if (dictionaryParameters == null) {
265 message = XACMLErrorConstants.ERROR_DATA_ISSUE + "Dictionary Parameters are not given.";
268 if (dictionaryParameters.getDictionaryType() == null
269 || dictionaryParameters.getDictionaryType().toString().trim().isEmpty()) {
270 message = XACMLErrorConstants.ERROR_DATA_ISSUE + "No Dictionary Type given.";
273 if (dictionaryParameters.getDictionary() == null || dictionaryParameters.getDictionary().trim().isEmpty()) {
274 message = XACMLErrorConstants.ERROR_DATA_ISSUE + "No Dictionary given.";
280 public DictionaryResponse getResult() {
281 return dictionaryResponse;
284 public HttpStatus getResponseCode() {