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