Fixed the SDK Junits and cleaned unused code

Moved file tmp object from try resources block. due to not closing the
stream the inputstream read by xacmlpolicyscanner ended with premature
file error.

Cleaned unused code.

Issue-ID: POLICY-584
Change-Id: I92c4d000d94a144736d9ac46db384785a7512593
Signed-off-by: rb7147 <rb7147@att.com>

2 files changed, 7 insertions, 491 deletions

diff --git a/POLICY-SDK-APP/src/main/java/org/onap/policy/admin/PolicyManagerServlet.java b/POLICY-SDK-APP/src/main/java/org/onap/policy/admin/PolicyManagerServlet.java
index 4d549fea2..b28850dd7 100644
--- a/POLICY-SDK-APP/src/main/java/org/onap/policy/admin/PolicyManagerServlet.java
+++ b/POLICY-SDK-APP/src/main/java/org/onap/policy/admin/PolicyManagerServlet.java
@@ -530,16 +530,15 @@ public class PolicyManagerServlet extends HttpServlet {
 		}
 		try (BufferedWriter bw = new BufferedWriter(new FileWriter(temp))) {
 			bw.write(entity.getPolicyData());
-			object = HumanPolicyComponent.DescribePolicy(temp);
 		} catch (IOException e) {
 			LOGGER.error("Exception Occured while Describing the Policy"+e);
-		}finally{
-			if(temp != null){
-				try {
-					Files.delete(temp.toPath());
-				} catch (IOException e) {
-					LOGGER.warn("Failed to delete " + temp.getName() + e);
-				}
+		}
+		object = HumanPolicyComponent.DescribePolicy(temp);
+		if(temp != null){
+			try {
+				Files.delete(temp.toPath());
+			} catch (IOException e) {
+				LOGGER.warn("Failed to delete " + temp.getName() + e);
 			}
 		}
 		return object;
diff --git a/POLICY-SDK-APP/src/main/java/org/onap/policy/utils/XACMLPolicyWriterWithPapNotify.java b/POLICY-SDK-APP/src/main/java/org/onap/policy/utils/XACMLPolicyWriterWithPapNotify.java
deleted file mode 100644
index 1cf2b7648..000000000
--- a/POLICY-SDK-APP/src/main/java/org/onap/policy/utils/XACMLPolicyWriterWithPapNotify.java
+++ /dev/null
@@ -1,483 +0,0 @@
-/*-
- * ============LICENSE_START=======================================================
- * ONAP Policy Engine
- * ================================================================================
- * Copyright (C) 2017-2018 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.utils;
-
-
-import java.io.IOException;
-import java.io.InputStream;
-import java.io.OutputStream;
-import java.io.UnsupportedEncodingException;
-import java.net.HttpURLConnection;
-import java.net.MalformedURLException;
-import java.net.ProtocolException;
-import java.net.URL;
-import java.net.URLEncoder;
-import java.nio.charset.StandardCharsets;
-import java.nio.file.DirectoryNotEmptyException;
-import java.nio.file.Files;
-import java.nio.file.Path;
-import java.util.Base64;
-import java.util.UUID;
-
-import org.onap.policy.rest.XACMLRestProperties;
-
-import org.onap.policy.xacml.api.XACMLErrorConstants;
-import org.onap.policy.xacml.util.XACMLPolicyWriter;
-import com.att.research.xacml.util.XACMLProperties;
-
-import oasis.names.tc.xacml._3_0.core.schema.wd_17.PolicySetType;
-import oasis.names.tc.xacml._3_0.core.schema.wd_17.PolicyType;
-
-import org.onap.policy.common.logging.flexlogger.FlexLogger; 
-import org.onap.policy.common.logging.flexlogger.Logger;
-
-/**
- * Helper static class that wraps XACMLPolicyWriter
- * 
- *
- */
-public class XACMLPolicyWriterWithPapNotify{
-	private static final Logger LOGGER = FlexLogger.getLogger(XACMLPolicyWriterWithPapNotify.class);
-	
-	private XACMLPolicyWriterWithPapNotify() {
-		// Add private constructor to hide the implicit public one
-	}
-
-	/**
-	 * Helper static class that does the work to write a policy set to a file on disk and notify PAP
-	 * 
-	 *
-	 */
-	public static Path writePolicyFile(Path filename, PolicySetType policySet) {
-		if(LOGGER.isDebugEnabled()){
-			LOGGER.debug("\nXACMLPolicyWriterWithPapNotify.writePolicyFile(Path filename, PolicySetType policySet)"
-					+ "\nfilename = " + filename
-					+ "\npolicySet = " + policySet);
-		}
-		//write to file
-		Path path = XACMLPolicyWriter.writePolicyFile(filename, policySet);
-		
-		if(path!=null){
-			//write to DB
-			if(notifyPapOfCreateUpdate(filename.toAbsolutePath().toString())){
-				return path;
-			}else{
-				//write to DB failed.  So, delete the file
-				try{
-					Files.deleteIfExists(path);
-				}catch(DirectoryNotEmptyException e){
-					//We are trying to delete a directory and it is not empty
-					LOGGER.error("\nXACMLPolicyWriterWithPapNotify.writePolicyFile(Path filename, PolicySetType policySet): Files.deleteIfExists(path)"
-							+ "\nDirectoryNotEmptyException for path = " + path
-							+ "\nException message = " + e);
-				}catch(IOException e) {
-				    // File permission problems are caught here.
-					LOGGER.error("\nXACMLPolicyWriterWithPapNotify.writePolicyFile(Path filename, PolicySetType policySet): Files.deleteIfExists(path)"
-							+ "\nIOException for path = " + path
-							+ "\nException message = " + e);
-				}catch(Exception e){
-					LOGGER.error("\nXACMLPolicyWriterWithPapNotify.writePolicyFile(Path filename, PolicySetType policySet): Files.deleteIfExists(path)"
-							+ "\nException for path = " + path
-							+ "\nException message = " + e);
-				}
-				return null;
-			}
-
-		}else{
-			return null;
-		}
-	}
-
-	/**
-	 * Helper static class that does the work to write a policy set to an output stream and notify PAP
-	 * 
-	 *
-	 */
-	public static void writePolicyFile(OutputStream os, PolicySetType policySet) {
-		if(LOGGER.isDebugEnabled()){
-			LOGGER.debug("\nXACMLPolicyWriterWithPapNotify.writePolicyFile(OutputStream os, PolicySetType policySet)"
-					+ "\nos = " + os
-					+ "\npolicySet = " + policySet);
-		}
-		//Only used for writing a byte array output stream for a message.  No file is written
-		XACMLPolicyWriter.writePolicyFile(os, policySet);
-	}
-
-	/**
-	 * Helper static class that does the work to write a policy to a file on disk.
-	 * 
-	 *
-	 */
-	public static Path writePolicyFile(Path filename, PolicyType policy) {
-		if(LOGGER.isDebugEnabled()){
-			LOGGER.debug("\nXACMLPolicyWriterWithPapNotify.writePolicyFile(Path filename, PolicyType policy)"
-					+ "\nfilename = " + filename
-					+ "\npolicy = " + policy);
-		}
-
-		//write to file
-		Path path = XACMLPolicyWriter.writePolicyFile(filename, policy);
-		
-		if(path!=null){
-			//write to DB			
-			if(notifyPapOfCreateUpdate(filename.toAbsolutePath().toString())){
-				return path;
-			}else{
-				//write to DB failed so delete the file
-				try{
-					Files.deleteIfExists(path);
-				}catch(DirectoryNotEmptyException e){
-					//We are trying to delete a directory and it is not empty
-					LOGGER.error("\nXACMLPolicyWriterWithPapNotify.writePolicyFile(Path filename, PolicySetType policySet)Files.deleteIfExists(path) :"
-							+ "\nDirectoryNotEmptyException for path = " + path
-							+ "\nException message = " + e);
-				}catch(IOException e) {
-				    // File permission problems are caught here.
-					LOGGER.error("\nXACMLPolicyWriterWithPapNotify.writePolicyFile(Path filename, PolicySetType policySet): Files.deleteIfExists(path)"
-							+ "\nIOException for path = " + path
-							+ "\nException message = " + e);
-				}catch(Exception e){
-					LOGGER.error("\nXACMLPolicyWriterWithPapNotify.writePolicyFile(Path filename, PolicySetType policySet): Files.deleteIfExists(path)"
-							+ "\nException for path = " + path
-							+ "\nException message = " + e);
-				}
-				return null;
-			}
-
-		}else{
-			return null;
-		}
-	}
-
-
-	/**
-	 * Helper static class that does the work to write a policy to a file on disk.
-	 * 
-	 *
-	 */
-	public static InputStream getXmlAsInputStream(PolicyType policy) {
-		if(LOGGER.isDebugEnabled()){
-			LOGGER.debug("\nXACMLPolicyWriterWithPapNotify.getXmlAsInputStream(PolicyType policy)"
-					+ "\npolicy = " + policy);
-		}
-		return XACMLPolicyWriter.getXmlAsInputStream(policy);
-	}
-	/**
-	 * Helper static class that does the work to write a policy set to an output stream.
-	 * 
-	 *
-	 */
-	public static void writePolicyFile(OutputStream os, PolicyType policy) {
-		if(LOGGER.isDebugEnabled()){
-			LOGGER.debug("\nXACMLPolicyWriterWithPapNotify.writePolicyFile(OutputStream os, PolicyType policy)"
-					+ "\nos = " + os
-					+ "\npolicy = " + policy);
-		}
-		//There are no references to this and if there were, it would most likely be used in an http message
-		XACMLPolicyWriter.writePolicyFile(os, policy);
-	}
-
-	public static String changeFileNameInXmlWhenRenamePolicy(Path filename) {
-		if(LOGGER.isDebugEnabled()){
-			LOGGER.debug("\nXACMLPolicyWriterWithPapNotify.changeFileNameInXmlWhenRenamePolicy(Path filename)"
-					+ "\nfilename = " + filename);
-		}
-		return XACMLPolicyWriter.changeFileNameInXmlWhenRenamePolicy(filename);
-	}
-	
-	public static boolean notifyPapOfPolicyRename(String oldPolicyName, String newPolicyName){
-		if(LOGGER.isDebugEnabled()){
-			LOGGER.debug("\nXACMLPolicyWriterWithPapNotify.notifyPapOfCreateUpdate(String policyToCreateUpdate) " 
-					+ "\npolicyToCreateUpdate = " + " ");
-		}
-		Base64.Encoder encoder = Base64.getEncoder();
-		String encoding = encoder.encodeToString((XACMLProperties.getProperty(XACMLRestProperties.PROP_PAP_USERID)+":"+CryptoUtils.decryptTxtNoExStr(XACMLProperties.getProperty(XACMLRestProperties.PROP_PAP_PASS))).getBytes(StandardCharsets.UTF_8));
-		HttpURLConnection connection;
-		UUID requestID = UUID.randomUUID();
-		URL url;
-		try {
-			url = new URL(XACMLProperties.getProperty(XACMLRestProperties.PROP_PAP_URL)+"?oldPolicyName="+ URLEncoder.encode(oldPolicyName, "UTF-8")+"&newPolicyName="+URLEncoder.encode(newPolicyName,"UTF-8"));
-			if(LOGGER.isDebugEnabled()){
-				LOGGER.debug("\nnotifyPapOfCreateUpdate: URL = " + url);
-			}
-		} catch (MalformedURLException e) {
-			LOGGER.error("\nnotifyPapOfCreateUpdate(String policyToCreateUpdate)"
-					+ "\nMalformedURLException message = " + e);
-			
-			return false;
-		} catch (UnsupportedEncodingException e) {
-			LOGGER.error("\nnotifyPapOfCreateUpdate(String policyToCreateUpdate)"
-					+ "\nUnsupportedEncodingException message = " + e);
-
-			return false;
-		}
-		//
-		// Open up the connection
-		//
-		try {
-			connection = (HttpURLConnection)url.openConnection();
-		} catch (IOException e) {
-			LOGGER.error("\nnotifyPapOfCreateUpdate(String policyToCreateUpdate)"
-					+ "\nurl.openConnection() IOException message = " + e);			
-			return false;
-		}
-		//
-		// Setup our method and headers
-		//
-        try {
-			connection.setRequestMethod("PUT");
-		} catch (ProtocolException e) {
-			LOGGER.error("\nnotifyPapOfCreateUpdate(String policyToCreateUpdate)"
-					+ "\nconnection.setRequestMethod(PUT) ProtocolException message = " + e);
-			connection.disconnect();
-			return false;
-		}
-        connection.setRequestProperty("Authorization", "Basic " + encoding);
-		connection.setRequestProperty("Accept", "text/x-java-properties");
-        connection.setRequestProperty("Content-Type", "text/x-java-properties");	  	        
-        connection.setRequestProperty("requestID", requestID.toString());
-        connection.setUseCaches(false);
-        //
-        // Adding this in. It seems the HttpUrlConnection class does NOT
-        // properly forward our headers for POST re-direction. It does so
-        // for a GET re-direction.
-        //
-        // So we need to handle this ourselves.
-        //
-        connection.setInstanceFollowRedirects(false);
-		connection.setDoOutput(true);
-		connection.setDoInput(true);
-        try {
-			connection.connect();
-		} catch (IOException e) {
-			LOGGER.error("\nnotifyPapOfCreateUpdate(String policyToCreateUpdate)"
-					+ "\nconnection.connect() IOException message = " + e);
-			connection.disconnect();
-			return false;
-		}
-        try {
-        	int responseCode = connection.getResponseCode();
-        	if(LOGGER.isDebugEnabled()){
-        		LOGGER.debug("\nnotifyPapOfCreateUpdate(String policyToCreateUpdate)"
-    					+ "\nconnection.getResponseCode() = " + responseCode);
-        	}
-			if (responseCode == 200) {
-				connection.disconnect();
-				return true;
-			} else {
-				connection.disconnect();
-				return false;
-			}
-		} catch (IOException e) {
-			LOGGER.error("\nnotifyPapOfCreateUpdate(String policyToCreateUpdate)"
-					+ "\nconnection.getResponseCode() IOException message = " + e);
-			connection.disconnect();
-			return false;
-		}
-	}
-	
-	public static boolean notifyPapOfDelete(String policyToDelete){
-		Base64.Encoder encoder = Base64.getEncoder();
-		String encoding = encoder.encodeToString((XACMLProperties.getProperty(XACMLRestProperties.PROP_PAP_USERID)+":"+CryptoUtils.decryptTxtNoExStr(XACMLProperties.getProperty(XACMLRestProperties.PROP_PAP_PASS))).getBytes(StandardCharsets.UTF_8));
-		HttpURLConnection connection;
-		UUID requestID = UUID.randomUUID();
-		String papUrl = XACMLProperties.getProperty(XACMLRestProperties.PROP_PAP_URL);
-		if(papUrl == null){
-			LOGGER.error(XACMLErrorConstants.ERROR_DATA_ISSUE + 
-					"PAP url property does not exist");
-			return false;
-		}
-		String urlString = "";
-		try{
-		urlString = papUrl+"?groupId=0&isDeleteNotify=1&policyToDelete="+ URLEncoder.encode(policyToDelete, "UTF-8");
-		} catch(UnsupportedEncodingException e){
-			LOGGER.error(XACMLErrorConstants.ERROR_DATA_ISSUE + 
-					"Invalid encoding: UTF-8", e);
-			return false;
-		}
-		URL url;
-		try {
-			url = new URL(urlString);
-		} catch (MalformedURLException e) {			
-			LOGGER.error(XACMLErrorConstants.ERROR_PROCESS_FLOW + 
-					"Error parsing PAP url: "
-							+ urlString
-							, e);				
-			return false;
-		}
-		//
-		// Open up the connection
-		//
-		try {
-			connection = (HttpURLConnection)url.openConnection();
-		} catch (IOException e) {
-			LOGGER.error(XACMLErrorConstants.ERROR_SYSTEM_ERROR + 
-					"Error opening HttpURLConnection to: "
-							+ url.toString()
-							, e);				
-			return false;
-		}
-		//
-		// Setup our method and headers
-		//
-        try {
-			connection.setRequestMethod("DELETE");
-		} catch (ProtocolException e) {
-			LOGGER.error(XACMLErrorConstants.ERROR_DATA_ISSUE + 
-					"Invalid request method: DELETE", e);
-			connection.disconnect();
-			return false;
-		}
-        connection.setRequestProperty("Authorization", "Basic " + encoding);
-		connection.setRequestProperty("Accept", "text/x-java-properties");
-        connection.setRequestProperty("Content-Type", "text/x-java-properties");	  	        
-        connection.setRequestProperty("requestID", requestID.toString());
-        connection.setUseCaches(false);
-        //
-        // Adding this in. It seems the HttpUrlConnection class does NOT
-        // properly forward our headers for POST re-direction. It does so
-        // for a GET re-direction.
-        //
-        // So we need to handle this ourselves.
-        //
-        connection.setInstanceFollowRedirects(false);
-		connection.setDoOutput(true);
-		connection.setDoInput(true);
-        try {
-			connection.connect();
-		} catch (IOException e) {
-			LOGGER.error(XACMLErrorConstants.ERROR_SYSTEM_ERROR + 
-					"Error connecting HttpURLConnection to: "
-							+ connection.getURL().toString()
-							, e);	
-			connection.disconnect();
-			return false;
-		}
-        try {
-			if (connection.getResponseCode() == 200) {
-				connection.disconnect();
-				//worked
-				return true;
-			} else {
-				connection.disconnect();
-				return false;
-			}
-		} catch (IOException e) {
-			LOGGER.error(XACMLErrorConstants.ERROR_SYSTEM_ERROR + 
-					"Error getting HttpUrlConnection response code for: "
-							+ connection.getURL().toString()
-							, e);
-			connection.disconnect();
-			return false;
-		}
-	}
-	
-	public static boolean notifyPapOfCreateUpdate(String policyToCreateUpdate){
-		if(LOGGER.isDebugEnabled()){
-			LOGGER.debug("\nXACMLPolicyWriterWithPapNotify.notifyPapOfCreateUpdate(String policyToCreateUpdate) " 
-					+ "\npolicyToCreateUpdate = " + policyToCreateUpdate);
-		}
-		Base64.Encoder encoder = Base64.getEncoder();
-		String encoding = encoder.encodeToString((XACMLProperties.getProperty(XACMLRestProperties.PROP_PAP_USERID)+":"+CryptoUtils.decryptTxtNoExStr(XACMLProperties.getProperty(XACMLRestProperties.PROP_PAP_PASS))).getBytes(StandardCharsets.UTF_8));
-		HttpURLConnection connection;
-		UUID requestID = UUID.randomUUID();
-		URL url;
-		try {
-			url = new URL(XACMLProperties.getProperty(XACMLRestProperties.PROP_PAP_URL)+"?policyToCreateUpdate="+ URLEncoder.encode(policyToCreateUpdate, "UTF-8"));
-			if(LOGGER.isDebugEnabled()){
-				LOGGER.debug("\nnotifyPapOfCreateUpdate: URL = " + url);
-			}
-		} catch (MalformedURLException e) {
-			LOGGER.error("\nnotifyPapOfCreateUpdate(String policyToCreateUpdate)"
-					+ "\nMalformedURLException message = " + e);
-			
-			return false;
-		} catch (UnsupportedEncodingException e) {
-			LOGGER.error("\nnotifyPapOfCreateUpdate(String policyToCreateUpdate)"
-					+ "\nUnsupportedEncodingException message = " + e);
-
-			return false;
-		}
-		//
-		// Open up the connection
-		//
-		try {
-			connection = (HttpURLConnection)url.openConnection();
-		} catch (IOException e) {
-			LOGGER.error("\nnotifyPapOfCreateUpdate(String policyToCreateUpdate)"
-					+ "\nurl.openConnection() IOException message = " + e);			
-			return false;
-		}
-		//
-		// Setup our method and headers
-		//
-        try {
-			connection.setRequestMethod("PUT");
-		} catch (ProtocolException e) {
-			LOGGER.error("\nnotifyPapOfCreateUpdate(String policyToCreateUpdate)"
-					+ "\nconnection.setRequestMethod(PUT) ProtocolException message = " + e);
-			connection.disconnect();
-			return false;
-		}
-        connection.setRequestProperty("Authorization", "Basic " + encoding);
-		connection.setRequestProperty("Accept", "text/x-java-properties");
-        connection.setRequestProperty("Content-Type", "text/x-java-properties");	  	        
-        connection.setRequestProperty("requestID", requestID.toString());
-        connection.setUseCaches(false);
-        //
-        // Adding this in. It seems the HttpUrlConnection class does NOT
-        // properly forward our headers for POST re-direction. It does so
-        // for a GET re-direction.
-        //
-        // So we need to handle this ourselves.
-        //
-        connection.setInstanceFollowRedirects(false);
-		connection.setDoOutput(true);
-		connection.setDoInput(true);
-        try {
-			connection.connect();
-		} catch (IOException e) {
-			LOGGER.error("\nnotifyPapOfCreateUpdate(String policyToCreateUpdate)"
-					+ "\nconnection.connect() IOException message = " + e);
-			connection.disconnect();
-			return false;
-		}
-        try {
-        	int responseCode = connection.getResponseCode();
-        	if(LOGGER.isDebugEnabled()){
-        		LOGGER.debug("\nnotifyPapOfCreateUpdate(String policyToCreateUpdate)"
-    					+ "\nconnection.getResponseCode() = " + responseCode);
-        	}
-			if (responseCode == 200) {
-				connection.disconnect();
-				return true;
-			} else {
-				connection.disconnect();
-				return false;
-			}
-		} catch (IOException e) {
-			LOGGER.error("\nnotifyPapOfCreateUpdate(String policyToCreateUpdate)"
-					+ "\nconnection.getResponseCode() IOException message = " + e);
-			connection.disconnect();
-			return false;
-		}
-	}
-}