+++ /dev/null
-/*-
- * ============LICENSE_START=======================================================
- * ECOMP Policy Engine
- * ================================================================================
- * 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.openecomp.policy.admin;
-
-
-import java.io.BufferedOutputStream;
-import java.io.BufferedReader;
-import java.io.File;
-import java.io.FileFilter;
-import java.io.FileInputStream;
-import java.io.FileOutputStream;
-import java.io.IOException;
-import java.io.InputStream;
-import java.io.OutputStream;
-import java.io.PrintWriter;
-import java.nio.file.DirectoryStream;
-import java.nio.file.Files;
-import java.nio.file.Path;
-import java.nio.file.Paths;
-import java.nio.file.attribute.BasicFileAttributes;
-import java.text.SimpleDateFormat;
-import java.util.ArrayList;
-import java.util.Arrays;
-import java.util.Date;
-import java.util.HashMap;
-import java.util.HashSet;
-import java.util.List;
-import java.util.Map;
-import java.util.Set;
-
-import javax.servlet.ServletException;
-import javax.servlet.http.HttpServlet;
-import javax.servlet.http.HttpServletRequest;
-import javax.servlet.http.HttpServletResponse;
-
-import org.apache.commons.compress.utils.IOUtils;
-import org.apache.commons.fileupload.FileItem;
-import org.apache.commons.fileupload.disk.DiskFileItemFactory;
-import org.apache.commons.fileupload.servlet.ServletFileUpload;
-import org.apache.commons.io.FileUtils;
-import org.apache.commons.io.FilenameUtils;
-import org.apache.commons.io.filefilter.WildcardFileFilter;
-import org.apache.http.HttpStatus;
-import org.json.JSONException;
-import org.json.JSONObject;
-import org.openecomp.policy.adapter.PolicyAdapter;
-import org.openecomp.policy.components.HumanPolicyComponent;
-import org.openecomp.policy.controller.ActionPolicyController;
-import org.openecomp.policy.controller.CreateBRMSParamController;
-import org.openecomp.policy.controller.CreateBRMSRawController;
-import org.openecomp.policy.controller.CreateClosedLoopFaultController;
-import org.openecomp.policy.controller.CreateClosedLoopPMController;
-import org.openecomp.policy.controller.CreateDcaeMicroServiceController;
-import org.openecomp.policy.controller.CreateFirewallController;
-import org.openecomp.policy.controller.CreatePolicyController;
-import org.openecomp.policy.controller.DecisionPolicyController;
-import org.openecomp.policy.controller.PolicyController;
-import org.openecomp.policy.controller.PolicyExportAndImportController;
-import org.openecomp.policy.elk.client.ElkConnector;
-import org.openecomp.policy.model.Roles;
-import org.openecomp.policy.rest.jpa.PolicyEditorScopes;
-import org.openecomp.policy.rest.jpa.PolicyVersion;
-import org.openecomp.policy.rest.jpa.UserInfo;
-import org.openecomp.policy.utils.XACMLPolicyWriterWithPapNotify;
-import org.openecomp.portalsdk.core.web.support.UserUtils;
-
-import org.openecomp.policy.common.logging.flexlogger.FlexLogger;
-import org.openecomp.policy.common.logging.flexlogger.Logger;
-
-import org.openecomp.policy.xacml.api.XACMLErrorConstants;
-import org.openecomp.policy.xacml.util.XACMLPolicyScanner;
-import com.fasterxml.jackson.databind.JsonNode;
-import com.fasterxml.jackson.databind.ObjectMapper;
-
-public class PolicyManagerServlet extends HttpServlet {
- private static final Logger LOG = FlexLogger.getLogger(PolicyManagerServlet.class);
- private static final long serialVersionUID = -8453502699403909016L;
-
- private enum Mode {
- LIST, RENAME, COPY, DELETE, EDITFILE, ADDFOLDER, DESCRIBEPOLICYFILE, VIEWPOLICY, ADDSUBSCOPE, SWITCHVERSION, EXPORT
- }
-
- public static final String REPOSITORY_BASE_PATH = PolicyController.getGitPath().toString();
- private static String DATE_FORMAT = "yyyy-MM-dd hh:mm:ss";
- public static final String CONFIG_HOME = PolicyController.getConfigHome();
- public static final String ACTION_HOME = PolicyController.getActionHome();
- private static String CONTENTTYPE = "application/json";
- private File repofilePath;
- private static String SUPERADMIN = "super-admin";
- private static String SUPEREDITOR = "super-editor";
- private static String SUPERGUEST = "super-guest";
- private static String ADMIN = "admin";
- private static String EDITOR = "editor";
- private static String GUEST = "guest";
- private static String RESULT = "result";
- private static String REPOSITORY = "repository";
-
- private static String CONFIG = "Config_";
- private static String ACTION = "Action_";
- private static String DECISION = "Decision_";
-
- @Override
- public void init() throws ServletException {
- super.init();
- }
-
- @Override
- public void doGet(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {
- String path = request.getParameter("path");
- File file = new File(REPOSITORY_BASE_PATH, path);
-
- if (!file.isFile()) {
- // if not a file, it is a folder, show this error.
- response.sendError(HttpServletResponse.SC_NOT_FOUND, "Resource Not Found");
- return;
- }
-
- response.setHeader("Content-Type", getServletContext().getMimeType(file.getName()));
- response.setHeader("Content-Length", String.valueOf(file.length()));
- response.setHeader("Content-Disposition", "inline; filename=\"" + file.getName() + "\"");
-
- FileInputStream input = null;
- BufferedOutputStream output = null;
- try {
- input = new FileInputStream(file);
- output = new BufferedOutputStream(response.getOutputStream());
- byte[] buffer = new byte[8192];
- for (int length = 0; (length = input.read(buffer)) > 0;) {
- output.write(buffer, 0, length);
- }
- } catch (Exception e) {
- LOG.error(XACMLErrorConstants.ERROR_DATA_ISSUE + "Exception Occured While Reading Imput Stream" + e);
- } finally {
- if (output != null) {
- try {
- output.close();
- } catch (Exception e) {
- LOG.error(XACMLErrorConstants.ERROR_DATA_ISSUE + "Exception Occured While Closing Output Stream" + e);
- }
- }
- if (input != null) {
- try {
- input.close();
- } catch (Exception e) {
- LOG.error(XACMLErrorConstants.ERROR_DATA_ISSUE + "Exception Occured While Closing Input Stream" + e);
- }
- }
- }
-
- }
-
- @Override
- protected void doPost(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {
- LOG.debug("doPost");
- try {
- // if request contains multipart-form-data
- if (ServletFileUpload.isMultipartContent(request)) {
- uploadFile(request, response);
- }
- // all other post request has json params in body
- else {
- fileOperation(request, response);
- }
- } catch (Exception e) {
- setError(e, response);
- }
- }
-
- //Set Error Message for Exception
- private void setError(Exception t, HttpServletResponse response) throws IOException {
- try {
- JSONObject responseJsonObject = error(t.getMessage());
- response.setContentType(CONTENTTYPE);
- PrintWriter out = response.getWriter();
- out.print(responseJsonObject);
- out.flush();
- } catch (Exception x) {
- response.sendError(HttpStatus.SC_INTERNAL_SERVER_ERROR, x.getMessage());
- }
- }
-
- //Policy Import Functionality
- private void uploadFile(HttpServletRequest request, HttpServletResponse response) throws ServletException {
- try {
- String newFile;
- Map<String, InputStream> files = new HashMap<String, InputStream>();
-
- List<FileItem> items = new ServletFileUpload(new DiskFileItemFactory()).parseRequest(request);
- for (FileItem item : items) {
- if (!item.isFormField()) {
- // Process form file field (input type="file").
- files.put(item.getName(), item.getInputStream());
- if(item.getName().endsWith(".tar")){
- try{
- File file = new File(item.getName());
- OutputStream outputStream = new FileOutputStream(file);
- IOUtils.copy(item.getInputStream(), outputStream);
- outputStream.close();
- newFile = file.toString();
- PolicyExportAndImportController importController = new PolicyExportAndImportController();
- importController.ImportRepositoryFile(newFile, request);
- }catch(Exception e){
- LOG.error("Upload error : " + e);
- }
- }
- }
- }
-
- JSONObject responseJsonObject = null;
- responseJsonObject = this.success();
- response.setContentType("application/json");
- PrintWriter out = response.getWriter();
- out.print(responseJsonObject);
- out.flush();
- } catch (Exception e) {
- LOG.debug("Cannot write file");
- throw new ServletException("Cannot write file", e);
- }
- }
-
- //File Operation Functionality
- private void fileOperation(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {
- JSONObject responseJsonObject = null;
- try {
- StringBuilder sb = new StringBuilder();
- BufferedReader br = request.getReader();
- String str;
- while ((str = br.readLine()) != null) {
- sb.append(str);
- }
- br.close();
- JSONObject jObj = new JSONObject(sb.toString());
- JSONObject params = jObj.getJSONObject("params");
- Mode mode = Mode.valueOf(params.getString("mode"));
- switch (mode) {
- case ADDFOLDER:
- responseJsonObject = addFolder(params, request);
- break;
- case COPY:
- responseJsonObject = copy(params, request);
- break;
- case DELETE:
- responseJsonObject = delete(params, request);
- break;
- case EDITFILE:
- responseJsonObject = editFile(params);
- break;
- case VIEWPOLICY:
- responseJsonObject = editFile(params);
- break;
- case LIST:
- responseJsonObject = list(params, request);
- break;
- case RENAME:
- responseJsonObject = rename(params, request);
- break;
- case DESCRIBEPOLICYFILE:
- responseJsonObject = describePolicy(params);
- break;
- case ADDSUBSCOPE:
- responseJsonObject = addFolder(params, request);
- break;
- case SWITCHVERSION:
- responseJsonObject = switchVersion(params, request);
- break;
- default:
- throw new ServletException("not implemented");
- }
- if (responseJsonObject == null) {
- responseJsonObject = error("generic error : responseJsonObject is null");
- }
- } catch (Exception e) {
- LOG.error(XACMLErrorConstants.ERROR_DATA_ISSUE + "Exception Occured While doing File Operation" + e);
- responseJsonObject = error(e.getMessage());
- }
- response.setContentType("application/json");
- PrintWriter out = response.getWriter();
- out.print(responseJsonObject);
- out.flush();
- }
-
- //Switch Version Functionality
- private JSONObject switchVersion(JSONObject params, HttpServletRequest request) throws ServletException{
- String path = params.getString("path");
- String userId = null;
- try {
- userId = UserUtils.getUserIdFromCookie(request);
- } catch (Exception e) {
- LOG.error("Exception Occured while reading userid from cookie" +e);
- }
- if(params.toString().contains("activeVersion")){
- String activeVersion = params.getString("activeVersion");
- String highestVersion = params.getString("highestVersion");
- if(Integer.parseInt(activeVersion) > Integer.parseInt(highestVersion)){
- return error("The Version shouldn't be greater than Highest Value");
- }else{
- String removeExtension = path.replace(".xml", "");
- String policyName = removeExtension.substring(0, removeExtension.lastIndexOf("."));
- String activePolicy = policyName + "." + activeVersion + ".xml";
- File file = new File(Paths.get(REPOSITORY_BASE_PATH, activePolicy).toString());
- if(!file.exists()){
- return error("The Policy is Not Existing in Workspace");
- }else{
- if(policyName.contains("/")){
- policyName = policyName.replace("/", File.separator);
- }
- policyName = policyName.substring(policyName.indexOf(File.separator)+1);
- if(policyName.contains("\\")){
- policyName = policyName.replace(File.separator, "\\");
- }
- String query = "update PolicyVersion set active_version='"+activeVersion+"' where policy_name ='" +policyName+"' and id >0";
- //query the database
- PolicyController.updatePolicyVersion(query);
- //Policy Notification
- PolicyController controller = new PolicyController();
- PolicyVersion entity = new PolicyVersion();
- entity.setPolicyName(policyName);
- entity.setActiveVersion(Integer.parseInt(activeVersion));
- entity.setModifiedBy(userId);
- controller.WatchPolicyFunction(entity, policyName, "SwitchVersion");
- }
- }
- }
- File policyFile = new File(REPOSITORY_BASE_PATH, path);
- PolicyController policyController = new PolicyController();
- return policyController.SwitchVersionPolicyContent(policyFile);
- }
-
- //Describe Policy
- private JSONObject describePolicy(JSONObject params){
- String path = params.getString("path");
- File policyFile = new File(REPOSITORY_BASE_PATH, path);
-
- return HumanPolicyComponent.DescribePolicy(policyFile);
- }
-
- //Get the List of Policies and Scopes for Showing in Editor tab
- private JSONObject list(JSONObject params, HttpServletRequest request) throws ServletException {
- Set<String> scopes = null;
- List<String> roles = null;
- try {
- //Get the Login Id of the User from Request
- String userId = UserUtils.getUserIdFromCookie(request);
- //Check if the Role and Scope Size are Null get the values from db.
- List<Roles> userRoles = PolicyController.getRoles(userId);
- roles = new ArrayList<String>();
- scopes = new HashSet<String>();
- for(Roles userRole: userRoles){
- roles.add(userRole.getRole());
- if(userRole.getScope() != null){
- if(userRole.getScope().contains(",")){
- String[] multipleScopes = userRole.getScope().split(",");
- for(int i =0; i < multipleScopes.length; i++){
- scopes.add(multipleScopes[i]);
- }
- }else{
- scopes.add(userRole.getScope());
- }
- }
- }
- if (roles.contains(ADMIN) || roles.contains(EDITOR) || roles.contains(GUEST) ) {
- if(scopes.isEmpty()){
- return error("No Scopes has been Assigned to the User. Please, Contact Super-Admin");
- }
- }
-
- List<JSONObject> resultList = new ArrayList<JSONObject>();
- SimpleDateFormat dt = new SimpleDateFormat(DATE_FORMAT);
- boolean onlyFolders = params.getBoolean("onlyFolders");
- String path = params.getString("path");
- if(path.contains("..xml")){
- path = path.replaceAll("..xml", "").trim();
- }
-
-
- if("/".equals(path)){
- if(roles.contains(SUPERADMIN) || roles.contains(SUPEREDITOR) || roles.contains(SUPERGUEST)){
- try (DirectoryStream<Path> directoryStream = Files.newDirectoryStream(Paths.get(REPOSITORY_BASE_PATH, path))) {
- for (Path pathObj : directoryStream) {
- BasicFileAttributes attrs = Files.readAttributes(pathObj, BasicFileAttributes.class);
- if (onlyFolders && !attrs.isDirectory()) {
- continue;
- }
- JSONObject el = new JSONObject();
- String fileName = pathObj.getFileName().toString();
- if (!(fileName.equals(".DS_Store") || fileName.contains(".git"))) {
- if(!fileName.endsWith(".xml")){
- el.put("name", fileName);
- el.put("date", dt.format(new Date(attrs.lastModifiedTime().toMillis())));
- el.put("size", attrs.size());
- el.put("type", attrs.isDirectory() ? "dir" : "file");
- resultList.add(el);
- }
- }
- }
- } catch (IOException ex) {
- LOG.error("Error Occured While reading Policy Files List"+ex );
- }
- }else if(roles.contains(ADMIN) || roles.contains(EDITOR) || roles.contains(GUEST)){
- for(Object scope : scopes){
- JSONObject el = new JSONObject();
- Path filePath = Paths.get(REPOSITORY_BASE_PATH + File.separator + scope);
- if(Files.exists(filePath)){
- el.put("name", scope);
- el.put("date", dt.format(filePath.toFile().lastModified()));
- el.put("size", "");
- el.put("type", "dir");
- resultList.add(el);
- }
- }
- }
- }else{
- try{
- String scopeName = path.substring(path.indexOf("/") +1);
- activePolicyList(scopeName, resultList, roles, scopes, onlyFolders);
- } catch (Exception ex) {
- LOG.error("Error Occured While reading Policy Files List"+ex );
- }
- }
-
- return new JSONObject().put(RESULT, resultList);
- } catch (Exception e) {
- LOG.error("list", e);
- return error(e.getMessage());
- }
- }
-
- //Get Active Policy List based on Scope Selection form Policy Version table
- private void activePolicyList(String scopeName, List<JSONObject> resultList, List<String> roles, Set<String> scopes, boolean onlyFolders){
- if(scopeName.contains("/")){
- scopeName = scopeName.replace("/", File.separator);
- }
- if(scopeName.contains("\\")){
- scopeName = scopeName.replace("\\", "\\\\\\\\");
- }
- String query = "from PolicyVersion where POLICY_NAME like'" +scopeName+"%'";
- String scopeNamequery = "from PolicyEditorScopes where SCOPENAME like'" +scopeName+"%'";
- List<PolicyVersion> activePolicies = PolicyController.getListOfActivePolicies(query);
- List<PolicyEditorScopes> scopesList = PolicyController.getListOfPolicyEditorScopes(scopeNamequery);
- for(PolicyEditorScopes scopeById : scopesList){
- String scope = scopeById.getScopeName();
- if(scope.contains(File.separator)){
- String checkScope = scope.substring(0, scope.lastIndexOf(File.separator));
- if(scopeName.contains("\\\\")){
- scopeName = scopeName.replace("\\\\", File.separator);
- }
- if(scopeName.equalsIgnoreCase(checkScope)){
- JSONObject el = new JSONObject();
- Path filePath = Paths.get(REPOSITORY_BASE_PATH + File.separator + scope);
- if(Files.exists(filePath)){
- el.put("name", filePath.getFileName());
- el.put("date", scopeById.getModifiedDate());
- el.put("size", "");
- el.put("type", "dir");
- el.put("createdBy", scopeById.getUserCreatedBy().getUserName());
- el.put("modifiedBy", scopeById.getUserModifiedBy().getUserName());
- resultList.add(el);
- }
- }
- }
- }
- for (PolicyVersion policy : activePolicies) {
- String scopeNameValue = policy.getPolicyName().substring(0, policy.getPolicyName().lastIndexOf(File.separator));
- String activepath = REPOSITORY_BASE_PATH + File.separator + policy.getPolicyName() + "." + policy.getActiveVersion() + ".xml";
- Path pathObj = Paths.get(activepath);
- if(Files.exists(pathObj)){
- BasicFileAttributes attrs;
- try {
- attrs = Files.readAttributes(pathObj, BasicFileAttributes.class);
- if (onlyFolders && !attrs.isDirectory()) {
- continue;
- }
- if(roles.contains(SUPERADMIN) || roles.contains(SUPEREDITOR) || roles.contains(SUPERGUEST)){
- readPolicies(pathObj, attrs, scopeName, resultList);
- }else if(!scopes.isEmpty()){
- for(String value : scopes){
- if(scopeNameValue.startsWith(value)){
- readPolicies(pathObj, attrs, scopeName, resultList);
- }
- }
- }
- } catch (Exception e) {
- LOG.error(XACMLErrorConstants.ERROR_PROCESS_FLOW+"Exception occured while reading File Attributes"+e);
- }
- }
- }
- }
-
- //Read the Policy File to get Created by and Modified by User Name of Policy
- public void readPolicies(Path pathObj, BasicFileAttributes attrs, String scopeName, List<JSONObject> resultList){
- JSONObject el = new JSONObject();
- String policyName = "";
- String version = "";
- String scope = "";
- if(scopeName.contains("\\\\")){
- scopeName = scopeName.replace("\\\\", File.separator);
- }
- SimpleDateFormat dt = new SimpleDateFormat(DATE_FORMAT);
- String fileName = pathObj.getFileName().toString();
- if (!(fileName.equals(".DS_Store") || fileName.startsWith(".git"))) {
- if(fileName.endsWith(".xml")){
- fileName = fileName.substring(0, fileName.lastIndexOf('.'));
- fileName = fileName.substring(0, fileName.lastIndexOf('.'));
- //Query the database
- String parent = pathObj.toString().substring(pathObj.toString().indexOf(REPOSITORY)+ 11);
- parent = FilenameUtils.removeExtension(parent);
- version = parent.substring(parent.indexOf(".")+1);
- policyName = parent.substring(0, parent.lastIndexOf("."));
- scope = policyName.substring(0, policyName.lastIndexOf(File.separator));
- if(policyName.contains("\\")){
- policyName = scope + "\\" + policyName.substring(policyName.lastIndexOf("\\"));
- }
- }
- if(scopeName.equalsIgnoreCase(scope)){
- el.put("name", fileName);
- if(pathObj.toFile().toString().endsWith(".xml")){
- el.put("version", version);
- List<String> createdByModifiedBy;
- try {
- createdByModifiedBy = XACMLPolicyScanner.getCreatedByModifiedBy(pathObj);
- } catch (IOException e) {
- LOG.error(XACMLErrorConstants.ERROR_PROCESS_FLOW + "Error while Reading the Policy File" + pathObj.toString() + e.getMessage());
- createdByModifiedBy = Arrays.asList("", "");
- }
- el.put("createdBy", getUserName(createdByModifiedBy.get(0)));
- el.put("modifiedBy", getUserName(createdByModifiedBy.get(1)));
- }
- el.put("date", dt.format(new Date(attrs.lastModifiedTime().toMillis())));
- el.put("size", attrs.size());
- el.put("type", attrs.isDirectory() ? "dir" : "file");
- }
- }
-
- if(!el.keySet().isEmpty()){
- resultList.add(el);
- }
-
- }
-
- //Get the User Name based on ID from User Info table
- public String getUserName(String userId) {
- String userName = "super-admin";
- if("".equals(userId)){
- return userName;
- }
- try{
- return PolicyController.getUserName(userId);
- }catch(Exception e){
- LOG.error(XACMLErrorConstants.ERROR_DATA_ISSUE+"Error Occured while Retriving User Name from User Info table"+e);
- return userName;
- }
- }
-
- //Rename Policy
- private JSONObject rename(JSONObject params, HttpServletRequest request) throws ServletException {
- try {
- String userId = null;
- try {
- userId = UserUtils.getUserIdFromCookie(request);
- } catch (Exception e) {
- LOG.error("Exception Occured while reading userid from cookie" +e);
- }
- String path = params.getString("path");
- String newpath = params.getString("newPath");
- LOG.debug("rename from: {} to:Â {}" +path + newpath);
-
- File srcFile = new File(REPOSITORY_BASE_PATH, path);
- File destFile = new File(REPOSITORY_BASE_PATH, newpath);
- if (srcFile.isFile()) {
- renameXMLandConfig(destFile.getPath().toString(), srcFile.getPath().toString(), userId);
- } else {
- FileUtils.moveDirectory(srcFile, destFile);
- String oldScopeName = path.substring(1).replace("/", File.separator);
- String newScopeName = newpath.substring(1).replace("/", File.separator);
- String scopeNamequery = "from PolicyEditorScopes where SCOPENAME like'" +oldScopeName.replace("\\", "\\\\\\\\")+"%'";
- UserInfo userInfo = new UserInfo();
- userInfo.setUserLoginId(userId);
- List<PolicyEditorScopes> scopesList = PolicyController.getListOfPolicyEditorScopes(scopeNamequery);
- for(PolicyEditorScopes scopes : scopesList){
- String scope = scopes.getScopeName();
- String newScope = scope.replace(oldScopeName, newScopeName);
- scopes.setScopeName(newScope);
- scopes.setUserModifiedBy(userInfo);
- PolicyController.updatePolicyScopeEditor(scopes);
- }
- File[] list = destFile.listFiles();
- if(list.length > 0){
- renameXMLandConfig(destFile.getPath().toString(), srcFile.getPath().toString(), userId);
- }
- }
- return success();
- } catch (Exception e) {
- LOG.error(XACMLErrorConstants.ERROR_DATA_ISSUE+"Exception Occured While Renaming Policy"+e);
- return error(e.getMessage());
- }
- }
-
- //rename the xml and config files when renaming scope
- public void renameXMLandConfig(String newPath, String oldPath, String loginId){
- if(!newPath.endsWith(".xml")){
- File dir = new File(newPath);
- File[] listOfFiles = dir.listFiles();
- for(File file : listOfFiles){
- if(file.toString().endsWith(".xml")){
- renameFile(file, oldPath, newPath );
- }else if(file.isDirectory()){
- String oldFilePath = oldPath + File.separator +file.getName();
- renameXMLandConfig(file.toString(), oldFilePath, loginId);
- }
- }
- }else{
- Path parent = Paths.get(oldPath.toString().substring(0, oldPath.toString().lastIndexOf(File.separator)));
- String policyName = oldPath.toString().substring(oldPath.toString().indexOf(REPOSITORY) +11);
- String removeExtension = policyName.replace(".xml", "");
- String dbPolicyName = removeExtension.substring(0, removeExtension.lastIndexOf("."));
- //Policy Notifcation
- PolicyController controller = new PolicyController();
- PolicyVersion entity = new PolicyVersion();
- entity.setPolicyName(dbPolicyName);
- entity.setModifiedBy(loginId);
- controller.WatchPolicyFunction(entity, dbPolicyName, "Rename");
- String filterPolicyName = dbPolicyName.substring(dbPolicyName.lastIndexOf(File.separator)+1);
- FileFilter fileFilter = new WildcardFileFilter(filterPolicyName + "." + "*" + ".xml");
- File[] files = parent.toFile().listFiles(fileFilter);
- for(File file : files){
- String removeNewPathExtension = newPath.replace(".xml", "");
- String removeNewFileVersion = removeNewPathExtension.substring(0, removeNewPathExtension.lastIndexOf("."));
- String oldFile = file.getPath();
- oldFile = oldFile.replace(".xml", "");
- String version = oldFile.substring(oldFile.lastIndexOf(".")+1);
- String finalPath = removeNewFileVersion + "." + version + ".xml";
- File destFile = new File(finalPath);
- try {
- FileUtils.moveFile(file, destFile);
- renameFile(file, oldFile, finalPath);
- } catch (IOException e) {
- LOG.error(XACMLErrorConstants.ERROR_DATA_ISSUE + "Exception Occured While Renaming or Moving Policy"+e);
- }
-
- }
- }
- }
-
- //Rename File
- private void renameFile(File file, String oldPath, String newPath){
- if(file.toString().contains(CONFIG) || file.toString().contains(ACTION) || file.toString().contains(DECISION)){
- File xmlFileName = new File(newPath);
- String oldfileWithExtension = null;
- String filelocation = null;
- String oldfile = null;
- String newfile = null;
- String extension = null;
- if(newPath.endsWith(".xml")){
- extension = XACMLPolicyWriterWithPapNotify.changeFileNameInXmlWhenRenamePolicy(xmlFileName.toPath());
- }else{
- extension = XACMLPolicyWriterWithPapNotify.changeFileNameInXmlWhenRenamePolicy(file.toPath());
- String fileName = file.getName();
- oldPath = oldPath + File.separator + fileName;
- newPath = newPath + File.separator + fileName;
- }
-
- try{
- if(file.toString().contains(CONFIG)){
- filelocation = PolicyController.getConfigHome();
- }
- if(file.toString().contains(ACTION)){
- filelocation = PolicyController.getActionHome();
- }
- File oldFilePath = new File(oldPath);
- String oldFileName = oldFilePath.getName().replace(".xml", "");
- File newFilePath = new File(newPath);
- String newFileName = newFilePath.getName().replace(".xml", "");
- File target = new File(oldPath);
- File newParentScope = new File(newPath);
- if(newParentScope.toString().endsWith(".xml")){
- String newScope = newParentScope.toString().substring(0, newParentScope.toString().lastIndexOf(File.separator));
- newParentScope = new File(newScope);
- }
- String oldParentScope = target.toString().substring(0, target.toString().lastIndexOf(File.separator));
- String oldDomain = oldParentScope.toString().substring(oldParentScope.toString().indexOf(REPOSITORY) + 11);
- if(oldDomain.endsWith(".xml")){
- oldDomain = oldDomain.substring(0, oldDomain.lastIndexOf(File.separator));
- }
- oldfile = oldDomain + File.separator + oldFileName.substring(0, oldFileName.indexOf("."));
- if(oldDomain.contains(File.separator)){
- oldDomain = oldDomain.replace(File.separator, ".");
- }
- String newDomain = newParentScope.toString().substring(newParentScope.toString().indexOf(REPOSITORY) + 11);
- newfile = newDomain + File.separator +newFileName.substring(0, newFileName.indexOf("."));
- if(newDomain.contains(File.separator)){
- newDomain = newDomain.replace(File.separator, ".");
- }
- if(file.toString().contains(CONFIG) || file.toString().contains(ACTION)){
- oldfileWithExtension = oldDomain + "." + oldFileName + "."+ extension;
- String newfilewithExtension = newDomain + "." + newFileName + "." + extension;
- File file1 = new File(filelocation, oldfileWithExtension);
- file1.renameTo(new File(filelocation , newfilewithExtension));
- }
- String query = "update PolicyVersion set policy_name='"+newfile.replace("\\", "\\\\")+"' where policy_name ='" +oldfile.replace("\\", "\\\\")+"' and id >0";
- //query the database
- PolicyController.updatePolicyVersion(query);
- }catch(Exception e){
- LOG.error(XACMLErrorConstants.ERROR_DATA_ISSUE +"Config file cannot found:" + oldfileWithExtension + e);
- }
- }
- }
-
- //Clone the Policy
- private JSONObject copy(JSONObject params, HttpServletRequest request) throws ServletException {
- try {
- String path = params.getString("path");
- String newpath = params.getString("newPath");
- LOG.debug("copy from: {} to:Â {}" + path +newpath);
- File srcFile = new File(REPOSITORY_BASE_PATH, path);
- File destFile = new File(REPOSITORY_BASE_PATH, newpath);
- if (srcFile.isFile()) {
- FileUtils.copyFile(srcFile, destFile);
- cloneXMLandConfig(destFile, srcFile, request);
- } else {
- FileUtils.copyDirectory(srcFile, destFile);
- }
- return success();
- } catch (Exception e) {
- LOG.error("copy", e);
- return error(e.getMessage());
- }
- }
-
- public void cloneXMLandConfig(File newPath, File oldPath, HttpServletRequest request){
- String userId = null;
- try {
- userId = UserUtils.getUserIdFromCookie(request);
- } catch (Exception e) {
- LOG.error("Exception Occured while reading userid from cookie" +e);
- }
- String newPolicyName = newPath.getPath().toString().substring(newPath.getPath().toString().indexOf(REPOSITORY) + 11);
- newPolicyName = newPolicyName.replace(".xml", "");
- String version = newPolicyName.substring(newPolicyName.lastIndexOf(".") +1);
- String policyName = newPolicyName.substring(0, newPolicyName.indexOf("."));
- newPolicyName = newPolicyName.replace(File.separator, ".");
- //if the user leaves the name of the policy blank
- if (newPolicyName == null) {
- return;
- }else{
- Path newPolicyPath = newPath.toPath();
- File dir = null;
- File[] listOfFiles = null;
- if(newPolicyName.contains(CONFIG)){
- LOG.debug("CONFIG_HOME: "+CONFIG_HOME);
- dir=new File(CONFIG_HOME);
- listOfFiles = dir.listFiles();
- }else if(newPolicyName.contains(ACTION)){
- LOG.debug("ACTION_HOME: "+ACTION_HOME);
- dir=new File(ACTION_HOME);
- listOfFiles = dir.listFiles();
- }
- String indexValue = "";
- String orignalPolicyName = oldPath.getPath().toString().substring(oldPath.getPath().toString().indexOf(REPOSITORY) + 11);
- orignalPolicyName = orignalPolicyName.replace(".xml", "");
- orignalPolicyName = orignalPolicyName.replace(File.separator, ".");
- if(orignalPolicyName.contains("Config_Fault_")){
- indexValue = "Config_Fault_";
- } else if(orignalPolicyName.contains("Config_PM_")){
- indexValue = "Config_PM_";
- }else if(orignalPolicyName.contains("Config_FW")){
- indexValue = "Config_FW_";
- }else if(orignalPolicyName.contains("Config_BRMS_Param")){
- indexValue = "Config_BRMS_Param_";
- }else if(orignalPolicyName.contains("Config_BRMS_Raw")){
- indexValue = "Config_BRMS_Raw_";
- } else if(orignalPolicyName.contains("Config_MS")){
- indexValue = "Config_MS_";
- }else if(orignalPolicyName.contains(ACTION)){
- indexValue = ACTION;
- }else if(orignalPolicyName.contains(DECISION)){
- indexValue = DECISION;
- }else{
- indexValue = CONFIG;
- }
- File newConfigFile = null;
-
- //making changes to the xml file
- if(indexValue.contains(CONFIG) || indexValue.contains(ACTION)){
- for (File file : listOfFiles) {
- if (file.isFile()){
- String fileName=file.getName();
- if(fileName.contains(orignalPolicyName)){
- String newConfigFileName=fileName.replaceAll(orignalPolicyName,newPolicyName);
- if(dir.toString().contains(File.separator)){
- newConfigFile=new File(dir.toString()+ File.separator +newConfigFileName);
- }
- try {
- Files.copy(file.toPath(), newConfigFile.toPath());
- } catch (Exception e) {
- LOG.error(XACMLErrorConstants.ERROR_DATA_ISSUE +"Error while Cloning the config file" + e);
- return;
- }
- }
- }
- }
- XACMLPolicyWriterWithPapNotify.changeFileNameInXmlWhenRenamePolicy(newPolicyPath);
- }
- //set the clone policy name into policy version database table
- PolicyVersion entityItem = new PolicyVersion();
- entityItem.setActiveVersion(Integer.parseInt(version));
- entityItem.setHigherVersion(Integer.parseInt(version));
- entityItem.setPolicyName(policyName);
- entityItem.setCreatedBy(userId);
- entityItem.setModifiedBy(userId);
- PolicyController.SaveToPolicyVersion(entityItem);
-
-
- new Thread(new Runnable() {
- @Override
- public void run() {
- try {
- ElkConnector.singleton.update(newPolicyPath.toFile());
- if (LOG.isInfoEnabled()) {
- LOG.info("ELK cloning to " + newPolicyPath);
- }
- } catch (Exception e) {
- LOG.warn(XACMLErrorConstants.ERROR_DATA_ISSUE + ": Internal Error: Unsucessful clone: " + e.getMessage(), e);
- }
- }
- }).start();
-
- //send to pap
- XACMLPolicyWriterWithPapNotify.notifyPapOfCreateUpdate(newPolicyPath.toAbsolutePath().toString());
- LOG.info("Cloned policy "+newPolicyName+" created successfully.");
- return;
- }
- }
-
- //Delete Policy or Scope Functionality
- private JSONObject delete(JSONObject params, HttpServletRequest request) throws ServletException {
- try {
- String userId = UserUtils.getUserIdFromCookie(request);
- String deleteVersion = "";
- String path1 = params.getString("path");
- LOG.debug("delete {}" +path1);
- if(params.has("deleteVersion")){
- deleteVersion = params.getString("deleteVersion");
- }
-
- this.repofilePath = new File(REPOSITORY_BASE_PATH, path1);
- File policyFile = new File(REPOSITORY_BASE_PATH, path1);
- if("ALL".equals(deleteVersion)){
- String removexmlExtension = policyFile.toString().substring(0, policyFile.toString().lastIndexOf("."));
- String removeVersion = removexmlExtension.substring(0, removexmlExtension.lastIndexOf("."));
- String notificationName = removeVersion.substring(removeVersion.lastIndexOf(REPOSITORY)+11);
- //Policy Notifcation
- PolicyController controller = new PolicyController();
- PolicyVersion entity = new PolicyVersion();
- entity.setPolicyName(notificationName);
- entity.setModifiedBy(userId);
- controller.WatchPolicyFunction(entity, notificationName, "DeleteAll");
- File dirXML = new File(policyFile.getParent());
- File[] listOfXMLFiles = dirXML.listFiles();
- for (File file : listOfXMLFiles) {
- //delete the xml files from Repository
- if (file.isFile() && file.toString().contains(removeVersion)) {
- if(XACMLPolicyWriterWithPapNotify.notifyPapOfDelete(file.toString())){
- LOG.info("Policy deleted from database. Continuing with file delete");
- } else {
- LOG.error("Failed to delete Policy from database. Aborting file delete");
- }
- //Elk Update
- updateElkOnPolicyDelete(file);
-
- if (file.delete()) {
- if (LOG.isDebugEnabled()) {
- LOG.debug("Deleted file: " + file.toString());
- }
- } else {
- LOG.warn(XACMLErrorConstants.ERROR_DATA_ISSUE + "Cannot delete the policy file in specified location: " + file.getAbsolutePath());
- }
-
- // Get tomcat home directory for deleting config data
- String path = getParentPathSubScopeDir();
- path = path.replace('\\', '.');
- if(path.contains("/")){
- path = path.replace('/', '.');
- }
- String fileName = FilenameUtils.removeExtension(file.getName());
- String removeVersionInFileName = fileName.substring(0, fileName.lastIndexOf("."));
- String fileLocation = null;
- if (fileName != null && fileName.contains(CONFIG)) {
- fileLocation = CONFIG_HOME;
- } else if (fileName != null && fileName.contains(ACTION)) {
- fileLocation = ACTION_HOME;
- }
- if (LOG.isDebugEnabled()) {
- LOG.debug("Attempting to rename file from the location: "+ fileLocation);
- }
- if(!file.toString().contains(DECISION)){
- // Get the file from the saved location
- File dir = new File(fileLocation);
- File[] listOfFiles = dir.listFiles();
-
- for (File file1 : listOfFiles) {
- if (file1.isFile() && file1.getName().contains( path + removeVersionInFileName)) {
- try {
- if (file1.delete() == false) {
- throw new Exception("No known error, Delete failed");
- }
- } catch (Exception e) {
- LOG.error("Failed to Delete file: "+ e.getLocalizedMessage());
- }
- }
- }
- }
-
- //Delete the Policy from Database Policy Version table
- String removeExtension = removeVersion.substring(removeVersion.indexOf(REPOSITORY)+11);
- String policyVersionQuery = "delete from PolicyVersion where policy_name ='" +removeExtension.replace("\\", "\\\\")+"' and id >0";
- if(policyVersionQuery != null){
- PolicyController.updatePolicyVersion(policyVersionQuery);
- }
- }
- }
- //If Only Particular version to be deleted
- }else if("CURRENT".equals(deleteVersion)){
- String removexmlExtension = policyFile.toString().substring(0, policyFile.toString().lastIndexOf("."));
- String getVersion = removexmlExtension.substring(removexmlExtension.indexOf(".")+1);
- String removeVersion = removexmlExtension.substring(0, removexmlExtension.lastIndexOf("."));
- String notificationName = removeVersion.substring(removeVersion.lastIndexOf(REPOSITORY)+11);
- //Policy Notifcation
- PolicyController controller = new PolicyController();
- PolicyVersion entity = new PolicyVersion();
- entity.setPolicyName(notificationName);
- entity.setActiveVersion(Integer.parseInt(getVersion));
- entity.setModifiedBy(userId);
- controller.WatchPolicyFunction(entity, notificationName, "DeleteOne");
- if(XACMLPolicyWriterWithPapNotify.notifyPapOfDelete(policyFile.toString())){
- LOG.info("Policy deleted from database. Continuing with file delete");
- } else {
- LOG.error("Failed to delete Policy from database. Aborting file delete");
- }
- //Elk Update
- updateElkOnPolicyDelete(policyFile);
-
- if (policyFile.delete()) {
- LOG.debug("Deleted file: " + policyFile.toString());
- } else {
- LOG.warn(XACMLErrorConstants.ERROR_DATA_ISSUE + "Cannot delete the policy file in specified location: " +policyFile.getAbsolutePath());
- }
-
- // Get tomcat home directory for storing action body config data
- String path = getParentPathSubScopeDir();
- path = path.replace('\\', '.');
- if(path.contains("/")){
- path = path.replace('/', '.');
- LOG.info("print the path:" +path);
- }
- final String tempPath = path;
- String fileName = FilenameUtils.removeExtension(policyFile.getName());
- String fileLocation = null;
- if (fileName != null && fileName.contains(CONFIG)) {
- fileLocation = CONFIG_HOME;
- } else if (fileName != null && fileName.contains(ACTION)) {
- fileLocation = ACTION_HOME;
- }
- if (LOG.isDebugEnabled()) {
- LOG.debug("Attempting to delete file from the location: "+ fileLocation);
- }
- if(!policyFile.toString().contains(DECISION)){
- // Get the file from the saved location
- File dir = new File(fileLocation);
- File[] listOfFiles = dir.listFiles();
-
- for (File file : listOfFiles) {
- if (file.isFile() && file.toString().contains( tempPath + fileName)) {
- try {
- if (file.delete() == false) {
- throw new Exception("No known error, Delete failed");
- }
- } catch (Exception e) {
- LOG.error("Failed to Delete file: "+ e.getLocalizedMessage());
- }
- }
- }
- }
- //Delete the Policy from Database and set Active Version based on the deleted file.
- int highestVersion = 0;
- String removeExtension = removeVersion.substring(removeVersion.indexOf(REPOSITORY)+11);
- PolicyVersion policyVersionEntity = PolicyController.getPolicyEntityFromPolicyVersion(removeExtension);
- if(policyVersionEntity != null){
- highestVersion = policyVersionEntity.getHigherVersion();
- }
- int i =0;
- int version = Integer.parseInt(getVersion);
- if(version == highestVersion){
- for(i = highestVersion; i >= 1 ; i--){
- highestVersion = highestVersion-1;
- path = removeVersion + "."+ highestVersion +".xml";
- File file = new File(path);
- if(file.exists()){
- break;
- }
- }
- }
- String updatequery = "update PolicyVersion set active_version='"+highestVersion+"' , highest_version='"+highestVersion+"' where policy_name ='" +removeExtension.replace("\\", "\\\\")+"'";
- PolicyController.updatePolicyVersion(updatequery);
- }else{
- String scopeName = policyFile.getAbsolutePath().substring(policyFile.getAbsolutePath().indexOf(REPOSITORY)+11);
- String policyVersionQuery = "delete PolicyVersion where POLICY_NAME like '"+scopeName.replace("\\", "\\\\")+"%' and id >0";
- String policyScopeQuery = "delete PolicyEditorScopes where SCOPENAME like '"+scopeName.replace("\\", "\\\\")+"%' and id >0";
- PolicyController.updatePolicyVersion(policyVersionQuery);
- PolicyController.updatePolicyScopeEditorWithQuery(policyScopeQuery);
- delete(policyFile);
- //Policy Notifcation
- PolicyController controller = new PolicyController();
- PolicyVersion entity = new PolicyVersion();
- entity.setPolicyName(scopeName);
- entity.setModifiedBy(userId);
- controller.WatchPolicyFunction(entity, scopeName, "DeleteScope");
- }
- return success();
- } catch (Exception e) {
- LOG.error("delete", e);
- return error(e.getMessage());
- }
- }
-
- //Notify ELK on File Delete
- private void updateElkOnPolicyDelete(File file){
- try {
- ElkConnector.singleton.delete(file);
- } catch (Exception e) {
- LOG.warn(XACMLErrorConstants.ERROR_DATA_ISSUE + ": Cannot delete: " + file.getName() +
- " at " + file.getAbsolutePath() + ": " + e.getMessage(), e);
- }
- }
- //Deletes Files when Scope is Selected to delete
- public void delete(File file) throws IOException{
- if(file.isDirectory()){
- //directory is empty, then delete it
- if(file.list().length==0){
- file.delete();
- }else{
- //list all the directory contents
- String[] files = file.list();
- for (String temp : files) {
- //construct the file structure
- File fileDelete = new File(file, temp);
- //delete from Elk first
- if(fileDelete.getAbsolutePath().toString().endsWith(".xml")){
- try {
- String deleteFile= fileDelete.getAbsoluteFile().toString().substring(fileDelete.getAbsoluteFile().toString().indexOf("workspace"));
- File deletePath= new File(deleteFile);
- LOG.debug("Search:"+deletePath);
- ElkConnector.singleton.delete(deletePath);
- } catch (Exception e) {
- LOG.warn(XACMLErrorConstants.ERROR_DATA_ISSUE + ": Cannot delete: " + fileDelete.getAbsoluteFile().getName() +
- " at " + fileDelete.getAbsoluteFile().getAbsolutePath() + ": " +e.getMessage(), e);
- }
- }
-
- //recursive delete
- delete(fileDelete);
-
- //Delete the Configuration files from Config and Action Home Location
- String fileLocation = null;
- String policyName = fileDelete.toString().substring(fileDelete.toString().indexOf(REPOSITORY)+11, fileDelete.toString().lastIndexOf("."));
- if(policyName.contains(CONFIG)){
- fileLocation = PolicyController.getConfigHome();
- }
- if(policyName.contains(ACTION)){
- fileLocation = PolicyController.getActionHome();
- }
- if(policyName.contains(File.separator)){
- policyName = policyName.replace(File.separator, ".");
- }
- if(!fileDelete.toString().contains(DECISION) && fileLocation != null){
- // Get the file from the saved location and delete
- File dir = new File(fileLocation);
- FileFilter fileFilter = new WildcardFileFilter(policyName + ".*");
- File[] configFiles = (dir).listFiles(fileFilter);
- if(configFiles.length > 0){
- configFiles[0].delete();
- }
- }
- //Notify the PAP and Elk database for deleting the Policies Under Scopes
- if(fileDelete.getAbsolutePath().toString().endsWith(".xml")){
- if(!XACMLPolicyWriterWithPapNotify.notifyPapOfDelete(fileDelete.getAbsolutePath().toString())){
- LOG.error(XACMLErrorConstants.ERROR_PROCESS_FLOW+"Could not delete the policy from the database: "+
- fileDelete.getAbsolutePath().toString());
- throw new IOException("Could not delete the policy from the database: "+
- fileDelete.getAbsolutePath().toString());
- }
- }
- }
- //check the directory again, if empty then delete it
- if(file.list().length==0){
- file.delete();
- }
- }
- }else{
- //if file, then delete it
- file.delete();
- }
- }
-
- //Get the Parent Scope of File
- protected String getParentPathSubScopeDir() {
- String domain1 = null;
- final Path gitPath = PolicyController.getGitPath();
- String policyDir = this.repofilePath.getAbsolutePath();
- int startIndex = policyDir.indexOf(gitPath.toString()) + gitPath.toString().length() + 1;
- policyDir = policyDir.substring(startIndex, policyDir.length());
- if(policyDir.contains(CONFIG)){
- domain1 = policyDir.substring(0,policyDir.indexOf(CONFIG));
- }else if(policyDir.contains(ACTION)){
- domain1 = policyDir.substring(0,policyDir.indexOf(ACTION));
- }else{
- domain1 = policyDir.substring(0,policyDir.indexOf(DECISION));
- }
- LOG.info("print the main domain value"+policyDir);
- return domain1;
- }
-
- //Edit the Policy
- private JSONObject editFile(JSONObject params) throws ServletException {
- // get content
- try {
- String mode = params.getString("mode");
- String path = params.getString("path");
- LOG.debug("editFile path: {}"+ path);
-
- File policyFile = new File(REPOSITORY_BASE_PATH, path);
-
- Object policy = XACMLPolicyScanner.readPolicy(new FileInputStream(policyFile));
- Path fullPath = Paths.get(policyFile.getAbsolutePath(), new String[0]);
- PolicyAdapter policyAdapter = new PolicyAdapter();
- policyAdapter.setData(policy);
- String dirPath = fullPath.getParent().toString().substring(fullPath.getParent().toString().lastIndexOf(REPOSITORY)+11);
- policyAdapter.setDirPath(dirPath);
- policyAdapter.setParentPath(fullPath.getParent());
-
- if("viewPolicy".equalsIgnoreCase(mode)){
- policyAdapter.setReadOnly(true);
- policyAdapter.setEditPolicy(false);
- }else{
- policyAdapter.setReadOnly(false);
- policyAdapter.setEditPolicy(true);
- }
-
- policyAdapter.setPolicyData(policy);
- policyAdapter.setPolicyName(FilenameUtils.removeExtension(policyFile.getName()));
-
- String policyNameValue = null ;
- String configPolicyName = null ;
- if(policyAdapter.getPolicyName().startsWith("Config_PM")){
- policyNameValue = policyAdapter.getPolicyName().substring(0, policyAdapter.getPolicyName().indexOf("_"));
- configPolicyName = "ClosedLoop_PM";
- }else if(policyAdapter.getPolicyName().startsWith("Config_Fault")){
- policyNameValue = policyAdapter.getPolicyName().substring(0, policyAdapter.getPolicyName().indexOf("_"));
- configPolicyName = "ClosedLoop_Fault";
- }else if(policyAdapter.getPolicyName().startsWith("Config_FW")){
- policyNameValue = policyAdapter.getPolicyName().substring(0, policyAdapter.getPolicyName().indexOf("_"));
- configPolicyName = "Firewall Config";
- }else if(policyAdapter.getPolicyName().startsWith("Config_BRMS_Raw")){
- policyNameValue = policyAdapter.getPolicyName().substring(0, policyAdapter.getPolicyName().indexOf("_"));
- configPolicyName = "BRMS_Raw";
- }else if(policyAdapter.getPolicyName().startsWith("Config_BRMS_Param")){
- policyNameValue = policyAdapter.getPolicyName().substring(0, policyAdapter.getPolicyName().indexOf("_"));
- configPolicyName = "BRMS_Param";
- }else if(policyAdapter.getPolicyName().startsWith("Config_MS")){
- policyNameValue = policyAdapter.getPolicyName().substring(0, policyAdapter.getPolicyName().indexOf("_"));
- configPolicyName = "DCAE Micro Service";
- }else if(policyAdapter.getPolicyName().startsWith("Action") || policyAdapter.getPolicyName().startsWith("Decision") ){
- policyNameValue = policyAdapter.getPolicyName().substring(0, policyAdapter.getPolicyName().indexOf("_"));
- }
- else{
- policyNameValue = policyAdapter.getPolicyName().substring(0, policyAdapter.getPolicyName().indexOf("_"));
- configPolicyName = "Base";
- }
- if (policyNameValue != null) {
- policyAdapter.setPolicyType(policyNameValue);
- }
- if (configPolicyName != null) {
- policyAdapter.setConfigPolicyType(configPolicyName);
- }
-
- if("Action".equalsIgnoreCase(policyAdapter.getPolicyType())){
- ActionPolicyController actionController = new ActionPolicyController();
- actionController.PrePopulateActionPolicyData(policyAdapter);
- }
- if("Decision".equalsIgnoreCase(policyAdapter.getPolicyType())){
- DecisionPolicyController decisionController = new DecisionPolicyController();
- decisionController.PrePopulateDecisionPolicyData(policyAdapter);
- }
- if("Config".equalsIgnoreCase(policyAdapter.getPolicyType())){
- if("Base".equalsIgnoreCase(policyAdapter.getConfigPolicyType())){
- CreatePolicyController baseController = new CreatePolicyController();
- baseController.PrePopulateBaseConfigPolicyData(policyAdapter);
- }
- else if("BRMS_Raw".equalsIgnoreCase(policyAdapter.getConfigPolicyType())){
- CreateBRMSRawController brmsController = new CreateBRMSRawController();
- brmsController.PrePopulateBRMSRawPolicyData(policyAdapter);
- }
- else if("BRMS_Param".equalsIgnoreCase(policyAdapter.getConfigPolicyType())){
- CreateBRMSParamController paramController = new CreateBRMSParamController();
- paramController.PrePopulateBRMSParamPolicyData(policyAdapter);
- }
- else if("ClosedLoop_Fault".equalsIgnoreCase(policyAdapter.getConfigPolicyType())){
- CreateClosedLoopFaultController newFaultTemplate = new CreateClosedLoopFaultController();
- newFaultTemplate.PrePopulateClosedLoopFaultPolicyData(policyAdapter);
- }
- else if("ClosedLoop_PM".equalsIgnoreCase(policyAdapter.getConfigPolicyType())){
- CreateClosedLoopPMController pmController = new CreateClosedLoopPMController();
- pmController.PrePopulateClosedLoopPMPolicyData(policyAdapter);
- }
- else if("DCAE Micro Service".equalsIgnoreCase(policyAdapter.getConfigPolicyType())){
- CreateDcaeMicroServiceController msController = new CreateDcaeMicroServiceController();
- msController.PrePopulateDCAEMSPolicyData(policyAdapter);
- }
- else if("Firewall Config".equalsIgnoreCase(policyAdapter.getConfigPolicyType())){
- CreateFirewallController firewallController = new CreateFirewallController();
- firewallController.PrePopulateFWPolicyData(policyAdapter);
- }
- }
-
-
- policyAdapter.setParentPath(null);
- ObjectMapper mapper = new ObjectMapper();
- String json = mapper.writeValueAsString(policyAdapter);
- JsonNode jsonNode = mapper.readTree(json);
-
- return new JSONObject().put(RESULT, jsonNode);
- } catch (Exception e) {
- LOG.error("editFile", e);
- return error(e.getMessage());
- }
- }
-
- //Add Scopes
- private JSONObject addFolder(JSONObject params, HttpServletRequest request) throws ServletException {
- String name = "";
-
- try {
- String userId = UserUtils.getUserIdFromCookie(request);
- String path = params.getString("path");
- try{
- if(params.has("subScopename")){
- if(!params.getString("subScopename").equals("")){
- name = params.getString("path").replace("/", File.separator) + File.separator +params.getString("subScopename");
- }
- }else{
- name = params.getString("name");
- }
- }catch(Exception e){
- name = params.getString("name");
- LOG.error(XACMLErrorConstants.ERROR_DATA_ISSUE + "Exception Occured While Adding Scope"+e);
- }
-
-
- LOG.debug("addFolder path: {} name: {}" + path +name);
- File newDir = new File(REPOSITORY_BASE_PATH, name);
- if(!newDir.exists()){
- if (!newDir.mkdir()) {
- throw new Exception("Can't create directory: " + newDir.getAbsolutePath());
- }
- UserInfo userInfo = new UserInfo();
- userInfo.setUserLoginId(userId);
- PolicyEditorScopes newScope = new PolicyEditorScopes();
- String scopeName = null;
- if(name.startsWith(File.separator)){
- scopeName = name.substring(1);
- }else{
- scopeName = name;
- }
- newScope.setScopeName(scopeName);
- newScope.setUserCreatedBy(userInfo);
- newScope.setUserModifiedBy(userInfo);
- PolicyController.SavePolicyScope(newScope);
- }else{
- return error("Scope Already Exists");
- }
-
- return success();
- } catch (Exception e) {
- LOG.error("addFolder", e);
- return error(e.getMessage());
- }
- }
-
- //Return Error Object
- private JSONObject error(String msg) throws ServletException {
- try {
- JSONObject result = new JSONObject();
- result.put("success", false);
- result.put("error", msg);
- return new JSONObject().put(RESULT, result);
- } catch (JSONException e) {
- throw new ServletException(e);
- }
- }
-
- //Return Success Object
- private JSONObject success() throws ServletException {
- try {
- JSONObject result = new JSONObject();
- result.put("success", true);
- result.put("error", (Object) null);
- return new JSONObject().put(RESULT, result);
- } catch (JSONException e) {
- throw new ServletException(e);
- }
- }
-}
Code Review / policy / engine.git / blobdiff