ONAP-PDP-REST/src/main/java/org/onap/policy/pdp/rest/api/services/GetDictionaryService.java

   1 /*-
   2  * ============LICENSE_START=======================================================
   3  * ONAP-PDP-REST
   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
  10  *
  11  *      http://www.apache.org/licenses/LICENSE-2.0
  12  *
  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=========================================================
  19  */
  20
  21 package org.onap.policy.pdp.rest.api.services;
  22
  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;
  35
  36 public class GetDictionaryService {
  37     private static final Logger LOGGER = FlexLogger.getLogger(GetDictionaryService.class.getName());
  38
  39     private DictionaryResponse dictionaryResponse = null;
  40     private HttpStatus status = HttpStatus.BAD_REQUEST;
  41     private String message = null;
  42     private DictionaryParameters dictionaryParameters = null;
  43
  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()) {
  49                 try {
  50                     requestUUID = UUID.fromString(requestID);
  51                 } catch (IllegalArgumentException e) {
  52                     requestUUID = UUID.randomUUID();
  53                     LOGGER.info("Generated Random UUID: " + requestUUID.toString(), e);
  54                 }
  55             } else {
  56                 requestUUID = UUID.randomUUID();
  57                 LOGGER.info("Generated Random UUID: " + requestUUID.toString());
  58             }
  59             this.dictionaryParameters.setRequestID(requestUUID);
  60         }
  61         try {
  62             run();
  63             specialCheck();
  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;
  69         }
  70     }
  71
  72     private void specialCheck() {
  73         if (dictionaryResponse != null && (dictionaryResponse.getResponseMessage() != null
  74                 && dictionaryResponse.getResponseMessage().contains("PE300"))) {
  75             status = HttpStatus.BAD_REQUEST;
  76         }
  77     }
  78
  79     private void run() throws PolicyException {
  80         // Check Validation.
  81         if (!getValidation()) {
  82             LOGGER.error(message);
  83             throw new PolicyException(message);
  84         }
  85         // Get Result.
  86         try {
  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);
  93         }
  94     }
  95
  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");
 102
 103         if (result != null && result.contains("data")) {
 104             String jsonString = formatDictionaryJson(result);
 105             String responseMessage = result.substring(0, 82);
 106             JsonObject json = null;
 107             try {
 108                 json = PolicyApiUtils.stringToJsonObject(jsonString.replace("\\\\\\", "\\"));
 109                 String datas = json.getString("data").replaceFirst("\"\\[", "[");
 110                 int i = datas.lastIndexOf("]");
 111                 if (i >= 0) {
 112                     datas = new StringBuilder(datas).replace(i, i + 2, "]").toString();
 113                 }
 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);
 121                 return response;
 122             }
 123             response.setResponseCode(papServices.getResponseCode());
 124             response.setDictionaryJson(json);
 125             response.setResponseMessage(responseMessage);
 126         } else {
 127             response.setResponseCode(400);
 128             response.setResponseMessage(result);
 129             if (result != null && result.contains("PE200")) {
 130                 status = HttpStatus.INTERNAL_SERVER_ERROR;
 131             } else {
 132                 status = HttpStatus.BAD_REQUEST;
 133             }
 134         }
 135         return response;
 136     }
 137
 138     private String formatDictionaryJson(String result) {
 139         String jsonString = result.substring(82);
 140         String dictionary = dictionaryParameters.getDictionary();
 141
 142         switch (dictionary) {
 143             case "OnapName":
 144                 jsonString = jsonString.replace("onapNameDictionaryDatas", "DictionaryDatas");
 145                 break;
 146             case "Attribute":
 147                 jsonString = jsonString.replace("attributeDictionaryDatas", "DictionaryDatas");
 148                 break;
 149             case "Action":
 150                 jsonString = jsonString.replace("actionPolicyDictionaryDatas", "DictionaryDatas");
 151                 break;
 152             case "BRMSParamTemplate":
 153                 jsonString = jsonString.replace("brmsParamDictionaryDatas", "DictionaryDatas");
 154                 break;
 155             case "VSCLAction":
 156                 jsonString = jsonString.replace("vsclActionDictionaryDatas", "DictionaryDatas");
 157                 break;
 158             case "VNFType":
 159                 jsonString = jsonString.replace("vnfTypeDictionaryDatas", "DictionaryDatas");
 160                 break;
 161             case "PepOptions":
 162                 jsonString = jsonString.replace("pepOptionsDictionaryDatas", "DictionaryDatas");
 163                 break;
 164             case "Varbind":
 165                 jsonString = jsonString.replace("varbindDictionaryDatas", "DictionaryDatas");
 166                 break;
 167             case "Service":
 168                 jsonString = jsonString.replace("closedLoopServiceDictionaryDatas", "DictionaryDatas");
 169                 break;
 170             case "Site":
 171                 jsonString = jsonString.replace("closedLoopSiteDictionaryDatas", "DictionaryDatas");
 172                 break;
 173             case "Settings":
 174                 jsonString = jsonString.replace("settingsDictionaryDatas", "DictionaryDatas");
 175                 break;
 176             case "RainyDayTreatments":
 177                 jsonString = jsonString.replace("rainyDayDictionaryDatas", "DictionaryDatas");
 178                 break;
 179             case "DescriptiveScope":
 180                 jsonString = jsonString.replace("descriptiveScopeDictionaryDatas", "DictionaryDatas");
 181                 break;
 182             case "Enforcer":
 183                 jsonString = jsonString.replace("enforcerDictionaryDatas", "DictionaryDatas");
 184                 break;
 185             case "ActionList":
 186                 jsonString = jsonString.replace("actionListDictionaryDatas", "DictionaryDatas");
 187                 break;
 188             case "ProtocolList":
 189                 jsonString = jsonString.replace("protocolListDictionaryDatas", "DictionaryDatas");
 190                 break;
 191             case "Zone":
 192                 jsonString = jsonString.replace("zoneDictionaryDatas", "DictionaryDatas");
 193                 break;
 194             case "SecurityZone":
 195                 jsonString = jsonString.replace("securityZoneDictionaryDatas", "DictionaryDatas");
 196                 break;
 197             case "PrefixList":
 198                 jsonString = jsonString.replace("prefixListDictionaryDatas", "DictionaryDatas");
 199                 break;
 200             case "AddressGroup":
 201                 jsonString = jsonString.replace("addressGroupDictionaryDatas", "DictionaryDatas");
 202                 break;
 203             case "ServiceGroup":
 204                 jsonString = jsonString.replace("serviceGroupDictionaryDatas", "DictionaryDatas");
 205                 break;
 206             case "ServiceList":
 207                 jsonString = jsonString.replace("serviceListDictionaryDatas", "DictionaryDatas");
 208                 break;
 209             case "TermList":
 210             case "RuleList":
 211             case "FirewallRuleList":
 212             case "Term":
 213                 jsonString = jsonString.replace("termListDictionaryDatas", "DictionaryDatas");
 214                 break;
 215             case "MicroServiceLocation":
 216                 jsonString = jsonString.replace("microServiceLocationDictionaryDatas", "DictionaryDatas");
 217                 break;
 218             case "MicroServiceConfigName":
 219                 jsonString = jsonString.replace("microServiceCongigNameDictionaryDatas", "DictionaryDatas");
 220                 break;
 221             case "MicroServiceDictionaryData":
 222                 jsonString = jsonString.replace("microServiceDictionaryDatas", "DictionaryDatas");
 223                 break;
 224             case "DCAEUUID":
 225                 jsonString = jsonString.replace("dcaeUUIDDictionaryDatas", "DictionaryDatas");
 226                 break;
 227             case "MicroServiceModels":
 228                 jsonString = jsonString.replace("microServiceModelsDictionaryDatas", "DictionaryDatas");
 229                 break;
 230             case "OptimizationModels":
 231                 jsonString = jsonString.replace("optmizationModelsDictionaryDatas", "DictionaryDatas");
 232                 break;
 233             case "PolicyScopeService":
 234                 jsonString = jsonString.replace("psServiceDictionaryDatas", "DictionaryDatas");
 235                 break;
 236             case "PolicyScopeResource":
 237                 jsonString = jsonString.replace("psResourceDictionaryDatas", "DictionaryDatas");
 238                 break;
 239             case "PolicyScopeType":
 240                 jsonString = jsonString.replace("psTypeDictionaryDatas", "DictionaryDatas");
 241                 break;
 242             case "PolicyScopeClosedLoop":
 243                 jsonString = jsonString.replace("psClosedLoopDictionaryDatas", "DictionaryDatas");
 244                 break;
 245             case "GroupPolicyScopeList":
 246                 jsonString = jsonString.replace("groupPolicyScopeListDatas", "DictionaryDatas");
 247                 break;
 248             case "RiskType":
 249                 jsonString = jsonString.replace("riskTypeDictionaryDatas", "DictionaryDatas");
 250                 break;
 251             case "SafePolicyWarning":
 252                 jsonString = jsonString.replace("safePolicyWarningDatas", "DictionaryDatas");
 253                 break;
 254             case "MicroServiceDictionary":
 255                 jsonString = jsonString.replace("microServiceDictionaryDatas", "DictionaryDatas");
 256                 break;
 257             default:
 258                 break;
 259         }
 260         return jsonString;
 261     }
 262
 263     private boolean getValidation() {
 264         if (dictionaryParameters == null) {
 265             message = XACMLErrorConstants.ERROR_DATA_ISSUE + "Dictionary Parameters are not given.";
 266             return false;
 267         }
 268         if (dictionaryParameters.getDictionaryType() == null
 269                 || dictionaryParameters.getDictionaryType().toString().trim().isEmpty()) {
 270             message = XACMLErrorConstants.ERROR_DATA_ISSUE + "No Dictionary Type given.";
 271             return false;
 272         }
 273         if (dictionaryParameters.getDictionary() == null || dictionaryParameters.getDictionary().trim().isEmpty()) {
 274             message = XACMLErrorConstants.ERROR_DATA_ISSUE + "No Dictionary given.";
 275             return false;
 276         }
 277         return true;
 278     }
 279
 280     public DictionaryResponse getResult() {
 281         return dictionaryResponse;
 282     }
 283
 284     public HttpStatus getResponseCode() {
 285         return status;
 286     }
 287
 288 }