ONAP-PAP-REST/src/main/java/org/onap/policy/pap/xacml/rest/handler/SavePolicyHandler.java

   1 /*-
   2  * ============LICENSE_START=======================================================
   3  * ONAP-PAP-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.pap.xacml.rest.handler;
  22
  23 import com.att.research.xacml.util.XACMLProperties;
  24 import java.io.IOException;
  25 import java.util.HashMap;
  26 import javax.servlet.ServletException;
  27 import javax.servlet.http.HttpServletRequest;
  28 import javax.servlet.http.HttpServletResponse;
  29 import javax.xml.parsers.ParserConfigurationException;
  30 import org.onap.policy.common.logging.eelf.PolicyLogger;
  31 import org.onap.policy.common.logging.flexlogger.FlexLogger;
  32 import org.onap.policy.common.logging.flexlogger.Logger;
  33 import org.onap.policy.pap.xacml.rest.policycontroller.PolicyCreation;
  34 import org.onap.policy.rest.adapter.PolicyRestAdapter;
  35 import org.onap.policy.utils.PolicyUtils;
  36 import org.onap.policy.xacml.std.pap.StdPAPPolicy;
  37 import org.xml.sax.SAXException;
  38
  39 public class SavePolicyHandler {
  40     private static final Logger logger = FlexLogger.getLogger(SavePolicyHandler.class);
  41     private HashMap<String, String> ErrorHeaders = null;
  42
  43     public void doPolicyAPIPut(HttpServletRequest request, HttpServletResponse response) throws IOException {
  44         String operation = request.getParameter("operation");
  45         String policyType = request.getParameter("policyType");
  46         String apiflag = request.getParameter("apiflag");
  47         PolicyCreation creation = new PolicyCreation();
  48         if ( policyType != null ) {
  49             PolicyRestAdapter policyAdapter = new PolicyRestAdapter();
  50             if("update".equalsIgnoreCase(operation)){
  51                 policyAdapter.setEditPolicy(true);
  52             }else{
  53                 policyAdapter.setEditPolicy(false);
  54             }
  55
  56             // get the request content into a String
  57             String json = null;
  58             // read the inputStream into a buffer (trick found online scans entire input looking for end-of-file)
  59             java.util.Scanner scanner = new java.util.Scanner(request.getInputStream());
  60             scanner.useDelimiter("\\A");
  61             json =  scanner.hasNext() ? scanner.next() : "";
  62             scanner.close();
  63
  64             if(policyAdapter.isEditPolicy()){
  65                 PolicyLogger.info("SavePolicyHandler: JSON request from API to update a policy: " + json);
  66             } else {
  67                 PolicyLogger.info("SavePolicyHandler: JSON request from API to create a policy: " + json);
  68             }
  69
  70             // convert Object sent as JSON into local object
  71             StdPAPPolicy policy = PolicyUtils.jsonStringToObject(json, StdPAPPolicy.class);
  72             //Set policyAdapter values including parentPath (Common to all policy types)
  73             try {
  74                 PolicyLogger.info("SavePolicyHandler: Setting parameter values to PolicyAdapter");
  75                 policyAdapter = setDataToPolicyAdapter(policy, policyType, apiflag);
  76
  77                 if(!extendedPolicyOptions(policyAdapter, response)){
  78                     creation.savePolicy(policyAdapter, response);
  79                 }
  80                 if ("update".equalsIgnoreCase(operation)) {
  81                     response.addHeader("operation",  "update");
  82                 } else {
  83                     response.addHeader("operation", "create");
  84                 }
  85             } catch (Exception e1) {
  86                 logger.error("Could not set data to policy adapter "+e1.getMessage(),e1);
  87             }
  88         }
  89     }
  90
  91     private PolicyRestAdapter setDataToPolicyAdapter(StdPAPPolicy policy, String policyType, String apiflag) throws ParserConfigurationException, ServletException, SAXException, IOException{
  92         PolicyRestAdapter policyAdapter = new PolicyRestAdapter();
  93         policyAdapter.setApiflag(apiflag);
  94         /*
  95          * set policy adapter values for Building JSON object containing policy data
  96          */
  97         //Common among policy types
  98         policyAdapter.setPolicyName(policy.getPolicyName());
  99         policyAdapter.setPolicyDescription(policy.getPolicyDescription());
 100         policyAdapter.setOnapName(policy.getOnapName()); //Config Base and Decision Policies
 101         policyAdapter.setRuleCombiningAlgId("urn:oasis:names:tc:xacml:3.0:rule-combining-algorithm:permit-overrides");
 102
 103         policyAdapter.setPolicyType(policyType);
 104         policyAdapter.setDynamicFieldConfigAttributes(policy.getDynamicFieldConfigAttributes());
 105         policyAdapter.setEditPolicy(policy.isEditPolicy());
 106         //Config Specific
 107         policyAdapter.setConfigName(policy.getConfigName());  //Base and Firewall
 108         policyAdapter.setConfigBodyData(policy.getConfigBodyData()); //Base
 109         policyAdapter.setConfigType((policy.getConfigType()!=null) ? policy.getConfigType().toUpperCase(): null);  //Base
 110         policyAdapter.setJsonBody(policy.getJsonBody()); //Firewall, ClosedLoop
 111         policyAdapter.setConfigPolicyType(policy.getConfigPolicyType());
 112         policyAdapter.setDraft(policy.isDraft()); //ClosedLoop_Fault
 113         policyAdapter.setServiceType(policy.getServiceType()); //ClosedLoop_PM
 114         policyAdapter.setUuid(policy.getUuid()); //Micro Service
 115         policyAdapter.setLocation(policy.getMsLocation()); //Micro Service
 116         policyAdapter.setPriority(policy.getPriority()); //Micro Service
 117         policyAdapter.setPolicyScope(policy.getDomainDir());
 118         policyAdapter.setRiskType(policy.getRiskType()); //Safe Policy Attributes
 119         policyAdapter.setRiskLevel(policy.getRiskLevel());//Safe Policy Attributes
 120         policyAdapter.setGuard(policy.getGuard());//Safe Policy Attributes
 121         policyAdapter.setTtlDate(policy.getTTLDate());//Safe Policy Attributes
 122         policyAdapter.setBrmsParamBody(policy.getDrlRuleAndUIParams());
 123         policyAdapter.setBrmsDependency(policy.getBrmsDependency()); // BRMS Policies.
 124         policyAdapter.setBrmsController(policy.getBrmsController()); // BRMS Policies.
 125         //Action Policy Specific
 126         policyAdapter.setActionAttribute(policy.getActionAttribute());  //comboDictValue
 127         policyAdapter.setActionPerformer(policy.getActionPerformer());
 128         policyAdapter.setDynamicRuleAlgorithmLabels(policy.getDynamicRuleAlgorithmLabels());
 129         policyAdapter.setDynamicRuleAlgorithmCombo(policy.getDynamicRuleAlgorithmCombo());
 130         policyAdapter.setDynamicRuleAlgorithmField1(policy.getDynamicRuleAlgorithmField1());
 131         policyAdapter.setDynamicRuleAlgorithmField2(policy.getDynamicRuleAlgorithmField2());
 132         //Decision Policy Specific
 133         policyAdapter.setDynamicSettingsMap(policy.getDynamicSettingsMap());
 134         policyAdapter.setRuleProvider(policy.getProviderComboBox());
 135         policyAdapter.setDomainDir(policyAdapter.getPolicyScope());
 136         policyAdapter.setRainydayMap(policy.getTreatments());
 137         policyAdapter.setRawXacmlPolicy(policy.getRawXacmlPolicy());
 138
 139         return policyAdapter;
 140     }
 141
 142     public boolean extendedPolicyOptions(PolicyRestAdapter policyAdapter, HttpServletResponse response){
 143         return false;
 144     }
 145
 146     public void addErrorHeader(String key, String value){
 147         if(ErrorHeaders==null){
 148             ErrorHeaders= new HashMap<>();
 149         }
 150         ErrorHeaders.put(key, value);
 151     }
 152
 153     public static SavePolicyHandler getInstance() {
 154         try {
 155             Class<?> savePolicyHandler = Class.forName(XACMLProperties.getProperty("savePolicy.impl.className", SavePolicyHandler.class.getName()));
 156             SavePolicyHandler instance = (SavePolicyHandler) savePolicyHandler.newInstance();
 157             return instance;
 158         } catch (Exception e) {
 159             logger.error(e.getMessage(),e);
 160         }
 161         return null;
 162     }
 163 }