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=========================================================
20 package org.onap.policy.pdp.rest.api.services;
22 import java.util.ArrayList;
23 import java.util.Arrays;
24 import java.util.Collection;
25 import java.util.HashMap;
26 import java.util.HashSet;
27 import java.util.List;
29 import java.util.UUID;
31 import javax.json.Json;
32 import javax.json.JsonArrayBuilder;
33 import javax.json.JsonObject;
34 import javax.json.JsonObjectBuilder;
36 import org.onap.policy.api.ConfigRequestParameters;
37 import org.onap.policy.api.PolicyConfigException;
38 import org.onap.policy.api.PolicyConfigStatus;
39 import org.onap.policy.common.logging.flexlogger.FlexLogger;
40 import org.onap.policy.common.logging.flexlogger.Logger;
41 import org.onap.policy.pdp.rest.api.models.PDPResponse;
42 import org.onap.policy.pdp.rest.api.models.PolicyConfig;
43 import org.onap.policy.xacml.api.XACMLErrorConstants;
44 import org.springframework.http.HttpStatus;
46 public class GetConfigService {
47 private static final Logger LOGGER = FlexLogger.getLogger(GetConfigService.class.getName());
49 private ConfigRequestParameters configRequestParameters = null;
50 private String message = null;
51 private HttpStatus responseCode = HttpStatus.BAD_REQUEST;
52 private Collection<PolicyConfig> policyConfigs = null;
53 private boolean unique = false;
55 public GetConfigService(ConfigRequestParameters configRequestParameters,
57 this.configRequestParameters = configRequestParameters;
58 if(configRequestParameters.getRequestID()==null){
59 UUID requestUUID = null;
60 if (requestID != null && !requestID.isEmpty()) {
62 requestUUID = UUID.fromString(requestID);
63 } catch (IllegalArgumentException e) {
64 requestUUID = UUID.randomUUID();
65 LOGGER.info("Generated Random UUID: " + requestUUID.toString(),e);
68 requestUUID = UUID.randomUUID();
69 LOGGER.info("Generated Random UUID: " + requestUUID.toString());
71 this.configRequestParameters.setRequestID(requestUUID);
73 policyConfigs = new ArrayList<>();
77 }catch(PolicyConfigException e){
79 PolicyConfig policyConfig = new PolicyConfig();
80 policyConfig.setPolicyConfigMessage(e.getMessage());
81 policyConfig.setPolicyConfigStatus(PolicyConfigStatus.CONFIG_NOT_FOUND);
82 policyConfigs.add(policyConfig);
83 responseCode = HttpStatus.BAD_REQUEST;
87 private void specialCheck() {
88 if(policyConfigs==null || policyConfigs.isEmpty()){
89 responseCode = HttpStatus.BAD_REQUEST;
90 }else if(policyConfigs.size()==1){
91 for(PolicyConfig policyConfig: policyConfigs){
92 if(policyConfig.getPolicyConfigMessage()!=null && policyConfig.getPolicyConfigMessage().contains("PE300")){
93 responseCode = HttpStatus.BAD_REQUEST;
97 responseCode = HttpStatus.OK;
101 private void run() throws PolicyConfigException{
103 if(!getValidation()){
104 LOGGER.error(message);
105 throw new PolicyConfigException(message);
108 String modelString = getModel().toString();
109 LOGGER.debug("Generated JSON Request is: " + modelString);
110 if(configRequestParameters.getUnique()){
111 LOGGER.info("Requested for Unique Result only. ");
116 PDPServices pdpServices = new PDPServices();
117 responseCode = HttpStatus.OK;
118 policyConfigs = configResult(pdpServices.generateRequest(modelString, configRequestParameters.getRequestID(), unique, false));
120 policyConfigs = filterResults(policyConfigs, configRequestParameters);
121 } catch (Exception e) {
122 LOGGER.error(XACMLErrorConstants.ERROR_DATA_ISSUE + e);
123 responseCode = HttpStatus.BAD_REQUEST;
124 throw new PolicyConfigException(XACMLErrorConstants.ERROR_DATA_ISSUE +e);
128 private Collection<PolicyConfig> configResult(
129 Collection<PDPResponse> generateRequest) {
130 Collection<PolicyConfig> result = new HashSet<>();
131 if (generateRequest == null) {
134 if (!generateRequest.isEmpty()) {
135 for (PDPResponse stdStatus : generateRequest) {
136 PolicyConfig policyConfig = new PolicyConfig();
137 policyConfig.setConfig(stdStatus.getConfig());
138 policyConfig.setMatchingConditions(stdStatus.getMatchingConditions());
139 policyConfig.setPolicyConfigMessage(stdStatus.getPolicyConfigMessage());
140 policyConfig.setPolicyConfigStatus(stdStatus.getPolicyConfigStatus());
141 policyConfig.setPolicyName(stdStatus.getPolicyName());
142 policyConfig.setPolicyVersion(stdStatus.getPolicyVersion());
143 policyConfig.setProperty(stdStatus.getProperty());
144 policyConfig.setResponseAttributes(stdStatus.getResponseAttributes());
145 policyConfig.setType(stdStatus.getType());
146 result.add(policyConfig);
152 // Filter logic required for results comparing with requests.
153 private Collection<PolicyConfig> filterResults(
154 Collection<PolicyConfig> policyConfigs,
155 ConfigRequestParameters configRequestParameters) {
156 List<PolicyConfig> policyConfig = new ArrayList<>();
157 for(PolicyConfig config: policyConfigs){
158 if(config.getPolicyName()!=null && configRequestParameters.getPolicyName()!=null && configRequestParameters.getPolicyName().trim().length()>0){
159 if(!config.getPolicyName().matches(configRequestParameters.getPolicyName())){
163 if(config.getMatchingConditions()!=null && config.getMatchingConditions().size()>0){
164 if(configRequestParameters.getOnapName()!=null && configRequestParameters.getOnapName().trim().length()>0 && config.getMatchingConditions().containsKey("ONAPName")){
165 if(!config.getMatchingConditions().get("ONAPName").matches(configRequestParameters.getOnapName())){
169 if(configRequestParameters.getConfigName()!=null && configRequestParameters.getConfigName().trim().length()>0 && config.getMatchingConditions().containsKey("ConfigName")){
170 if(!config.getMatchingConditions().get("ConfigName").matches(configRequestParameters.getConfigName())){
174 if(configRequestParameters.getConfigAttributes()!=null && configRequestParameters.getConfigAttributes().size()>0){
175 boolean flag = false;
176 for(String key: configRequestParameters.getConfigAttributes().keySet()){
177 if(key.equals("RiskType")||key.equals("RiskLevel")||key.equals("guard")||key.equals("TTLDate")){
180 if(config.getMatchingConditions().containsKey(key)){
181 if(config.getMatchingConditions().get(key).contains(",")){
182 List<String> elements = Arrays.asList(config.getMatchingConditions().get(key).split(","));
183 if(!elements.contains(configRequestParameters.getConfigAttributes().get(key))){
186 }else if(!config.getMatchingConditions().get(key).matches(configRequestParameters.getConfigAttributes().get(key))){
201 policyConfig.add(config);
203 if(policyConfig.isEmpty()){
204 PolicyConfig pConfig = new PolicyConfig();
205 pConfig.setPolicyConfigStatus(PolicyConfigStatus.CONFIG_NOT_FOUND);
206 pConfig.setPolicyConfigMessage(XACMLErrorConstants.ERROR_DATA_ISSUE+"No Match Found, for the parameters sent.");
207 policyConfig.add(pConfig);
212 private JsonObject getModel() throws PolicyConfigException{
213 String policyName = configRequestParameters.getPolicyName();
214 if(policyName!= null && !policyName.trim().isEmpty() && !policyName.endsWith("xml")){
215 policyName = policyName + ".[\\d].*";
216 configRequestParameters.setPolicyName(policyName);
218 JsonArrayBuilder subjectArray = Json.createArrayBuilder();
219 JsonArrayBuilder resourceArray = Json.createArrayBuilder();
220 if(configRequestParameters.getPolicyName()!=null){
221 JsonObjectBuilder subjectBuilder = Json.createObjectBuilder();
222 subjectBuilder.add("Value", policyName);
223 subjectBuilder.add("AttributeId", "PolicyName");
224 subjectArray.add(subjectBuilder);
226 LOGGER.info("PolicyName values are not given. ");
228 if(configRequestParameters.getOnapName()!=null){
229 JsonObjectBuilder subjectBuilder = Json.createObjectBuilder();
230 subjectBuilder.add("Value", configRequestParameters.getOnapName());
231 subjectBuilder.add("AttributeId", "ONAPName");
232 subjectArray.add(subjectBuilder);
233 if(configRequestParameters.getConfigName()!=null){
234 subjectBuilder = Json.createObjectBuilder();
235 subjectBuilder.add("Value", configRequestParameters.getConfigName());
236 subjectBuilder.add("AttributeId", "ConfigName");
237 subjectArray.add(subjectBuilder);
238 resourceArray = getResourceArray(configRequestParameters.getConfigAttributes());
240 LOGGER.info("Config Name is not given. ");
243 LOGGER.info("Onap Name is not given. ");
245 return Json.createObjectBuilder()
246 .add("Request",Json.createObjectBuilder()
247 .add("AccessSubject",Json.createObjectBuilder()
248 .add("Attribute",subjectArray))
249 .add("Action",Json.createObjectBuilder()
250 .add("Attribute",Json.createObjectBuilder()
251 .add("Value","ACCESS")
252 .add("AttributeId","urn:oasis:names:tc:xacml:1.0:action:action-id")))
253 .add("Resource",Json.createObjectBuilder()
254 .add("Attribute",resourceArray
255 .add(Json.createObjectBuilder()
256 .add("Value","Config")
257 .add("AttributeId","urn:oasis:names:tc:xacml:1.0:resource:resource-id")))))
261 private JsonArrayBuilder getResourceArray(Map<String, String> configAttributes) throws PolicyConfigException{
262 JsonArrayBuilder resourceArray = Json.createArrayBuilder();
263 configAttributes = configRequestParameters.getConfigAttributes();
264 if (configAttributes != null && !configAttributes.isEmpty()) {
265 if(!configAttributes.containsKey("RiskType")){
266 configAttributes.put("RiskType", ".*");
268 if(!configAttributes.containsKey("RiskLevel")){
269 configAttributes.put("RiskLevel", ".*");
271 if(!configAttributes.containsKey("guard")){
272 configAttributes.put("guard", ".*");
274 if(!configAttributes.containsKey("TTLDate")){
275 configAttributes.put("TTLDate", ".*");
278 // ConfigAttributes is Null. So add basic values.
279 configAttributes = new HashMap<>();
280 configAttributes.put("RiskType", ".*");
281 configAttributes.put("RiskLevel", ".*");
282 configAttributes.put("guard", ".*");
283 configAttributes.put("TTLDate", ".*");
285 for (String key : configAttributes.keySet()) {
287 String message = XACMLErrorConstants.ERROR_DATA_ISSUE + "Cannot have an Empty Key";
288 LOGGER.error(message);
289 throw new PolicyConfigException(message);
291 JsonObjectBuilder resourceBuilder = Json.createObjectBuilder();
292 resourceBuilder.add("Value", configAttributes.get(key));
293 resourceBuilder.add("AttributeId", key);
294 resourceArray.add(resourceBuilder);
296 return resourceArray;
299 private Boolean getValidation(){
300 if(configRequestParameters==null){
301 message = XACMLErrorConstants.ERROR_DATA_ISSUE + "No config Request Parameters given.";
304 if(configRequestParameters.getOnapName()==null && configRequestParameters.getPolicyName()==null){
305 message = XACMLErrorConstants.ERROR_DATA_ISSUE + "Cannot proceed without onapName or PolicyName";
311 public Collection<PolicyConfig> getResult() {
312 return policyConfigs;
315 public HttpStatus getResponseCode() {