[POLICY-73] replace openecomp for policy-engine

[policy/engine.git] / ONAP-PAP-REST / src / main / java / org / onap / policy / pap / xacml / rest / handler / PushPolicyHandler.java

diff --git a/ONAP-PAP-REST/src/main/java/org/onap/policy/pap/xacml/rest/handler/PushPolicyHandler.java b/ONAP-PAP-REST/src/main/java/org/onap/policy/pap/xacml/rest/handler/PushPolicyHandler.java
new file mode 100644 (file)
index 0000000..9ef0e6f
--- /dev/null
+++ b/ONAP-PAP-REST/src/main/java/org/onap/policy/pap/xacml/rest/handler/PushPolicyHandler.java
@@ -0,0 +1,123 @@
+/*-
+ * ============LICENSE_START=======================================================
+ * ONAP-PAP-REST
+ * ================================================================================
+ * Copyright (C) 2017 AT&T Intellectual Property. All rights reserved.
+ * ================================================================================
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ * 
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ * 
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ * ============LICENSE_END=========================================================
+ */
+package org.onap.policy.pap.xacml.rest.handler;
+
+import java.io.File;
+import java.net.URI;
+import java.util.List;
+
+import javax.persistence.EntityManager;
+import javax.persistence.Query;
+import javax.servlet.http.HttpServletRequest;
+import javax.servlet.http.HttpServletResponse;
+
+import org.onap.policy.common.logging.eelf.MessageCodes;
+import org.onap.policy.common.logging.eelf.PolicyLogger;
+import org.onap.policy.pap.xacml.rest.XACMLPapServlet;
+import org.onap.policy.rest.jpa.PolicyVersion;
+import org.onap.policy.xacml.api.pap.OnapPDPGroup;
+import org.onap.policy.xacml.std.pap.StdPDPPolicy;
+
+import com.att.research.xacml.util.XACMLProperties;
+
+public class PushPolicyHandler {
+       
+       /*
+        * Get Active Version. 
+        */
+       public void getActiveVersion(HttpServletRequest request, HttpServletResponse response) {
+               EntityManager em = null;
+               if(XACMLPapServlet.getEmf()!=null){
+                       em = (EntityManager) XACMLPapServlet.getEmf().createEntityManager();
+               }
+               if (em==null){
+                       PolicyLogger.error(MessageCodes.ERROR_DATA_ISSUE + " Error creating entity manager with persistence unit: " + XACMLPapServlet.getPersistenceUnit());
+                       return;
+               }
+               String policyScope = request.getParameter("policyScope");
+               String filePrefix = request.getParameter("filePrefix");
+               String policyName = request.getParameter("policyName");
+
+               String pvName = policyScope + File.separator + filePrefix + policyName;
+               int activeVersion = 0;
+
+               //Get the Active Version to use in the ID
+               em.getTransaction().begin();
+               Query query = em.createQuery("Select p from PolicyVersion p where p.policyName=:pname");
+               query.setParameter("pname", pvName);
+
+               @SuppressWarnings("rawtypes")
+               List result = query.getResultList();
+               PolicyVersion versionEntity = null;
+               if (!result.isEmpty()) {
+                       versionEntity = (PolicyVersion) result.get(0);
+                       em.persist(versionEntity);
+                       activeVersion = versionEntity.getActiveVersion();
+                       em.getTransaction().commit();
+               } else {
+                       PolicyLogger.debug("No PolicyVersion using policyName found");
+               }
+
+               //clean up connection
+               em.close();
+               if (String.valueOf(activeVersion)!=null || !String.valueOf(activeVersion).equalsIgnoreCase("")) {                                                       
+                       response.setStatus(HttpServletResponse.SC_OK);                                                          
+                       response.addHeader("version", String.valueOf(activeVersion));                                                           
+               } else {
+                       response.setStatus(HttpServletResponse.SC_NOT_FOUND);                                                           
+               }
+       }
+       
+       /*
+        * Get Selected URI path. 
+        */
+       public void getSelectedURI(HttpServletRequest request, HttpServletResponse response) {
+               String gitPath = request.getParameter("gitPath");
+               File file = new File(gitPath);
+               PolicyLogger.debug("The fileItem is : " + file.toString());
+               URI selectedURI = file.toURI();
+               String uri = selectedURI.toString();
+               if (!uri.equalsIgnoreCase("")) {                                                        
+                       response.setStatus(HttpServletResponse.SC_OK);                                                          
+                       response.addHeader("selectedURI", uri);                                                         
+               } else {                                                
+                       response.setStatus(HttpServletResponse.SC_NOT_FOUND);                                                           
+               }                                               
+       }
+       
+       public boolean preSafetyCheck(StdPDPPolicy policy, String configHome){
+               return true;
+       }
+       
+       public boolean preSafetyCheck(OnapPDPGroup policy, String configHome){
+               return true;
+       }
+       
+       public static PushPolicyHandler getInstance() {
+               try {
+                       Class<?> pushPolicyHandler = Class.forName(XACMLProperties.getProperty("pushPolicy.impl.className", PushPolicyHandler.class.getName()));
+                       PushPolicyHandler instance = (PushPolicyHandler) pushPolicyHandler.newInstance(); 
+                       return instance;
+               } catch (Exception e) {
+                       PolicyLogger.error(e.getMessage());
+               }
+               return null;
+       }
+}