init code

Change-Id: Icd0948118397b256da70dfbcbbec5520dc5eafd4
Signed-off-by: Zhaoxing <meng.zhaoxing1@zte.com.cn>

1 files changed, 0 insertions, 632 deletions

diff --git a/wso2bpel-ext/wso2bpel-core/wso2bpel-mgr/src/main/java/org/openo/carbon/bpel/resources/BpsPackage.java b/wso2bpel-ext/wso2bpel-core/wso2bpel-mgr/src/main/java/org/openo/carbon/bpel/resources/BpsPackage.java
deleted file mode 100644
index e11c1eb..0000000
--- a/wso2bpel-ext/wso2bpel-core/wso2bpel-mgr/src/main/java/org/openo/carbon/bpel/resources/BpsPackage.java
+++ /dev/null
@@ -1,632 +0,0 @@
-/**
- * Copyright 2016-2017 ZTE Corporation.
- *
- * 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.
- */
-package org.openo.carbon.bpel.resources;
-
-import java.io.File;
-import java.io.IOException;
-import java.io.InputStream;
-import java.util.ArrayList;
-import java.util.HashMap;
-import java.util.HashSet;
-import java.util.Iterator;
-import java.util.LinkedHashMap;
-import java.util.List;
-import java.util.Map;
-import java.util.Set;
-import java.util.concurrent.atomic.AtomicLong;
-
-import javax.activation.DataHandler;
-import javax.activation.DataSource;
-import javax.activation.FileDataSource;
-import javax.servlet.http.HttpServletRequest;
-import javax.servlet.http.HttpServletResponse;
-import javax.ws.rs.QueryParam;
-import javax.ws.rs.Consumes;
-import javax.ws.rs.DELETE;
-import javax.ws.rs.GET;
-import javax.ws.rs.POST;
-import javax.ws.rs.Path;
-import javax.ws.rs.PathParam;
-import javax.ws.rs.Produces;
-import javax.ws.rs.client.Client;
-import javax.ws.rs.client.ClientBuilder;
-import javax.ws.rs.client.Entity;
-import javax.ws.rs.client.WebTarget;
-import javax.ws.rs.core.Context;
-import javax.ws.rs.core.MediaType;
-import javax.xml.namespace.QName;
-
-import org.apache.axiom.om.OMAbstractFactory;
-import org.apache.axiom.om.OMElement;
-import org.apache.axiom.om.OMFactory;
-import org.apache.axiom.om.OMNamespace;
-import org.apache.axis2.AxisFault;
-import org.apache.axis2.addressing.EndpointReference;
-import org.apache.axis2.client.Options;
-import org.apache.axis2.rpc.client.RPCServiceClient;
-import org.apache.axis2.transport.http.HTTPConstants;
-import org.apache.axis2.transport.http.HttpTransportProperties;
-import org.apache.axis2.transport.http.HttpTransportProperties.Authenticator;
-import org.apache.commons.io.FileUtils;
-import org.apache.commons.logging.Log;
-import org.apache.commons.logging.LogFactory;
-import org.glassfish.jersey.media.multipart.FormDataContentDisposition;
-import org.glassfish.jersey.media.multipart.FormDataMultiPart;
-import org.glassfish.jersey.media.multipart.FormDataParam;
-import org.glassfish.jersey.media.multipart.MultiPartFeature;
-import org.glassfish.jersey.media.multipart.file.FileDataBodyPart;
-import org.wso2.carbon.bpel.stub.upload.types.UploadedFileItem;
-import org.openo.carbon.bpel.common.Config;
-import org.openo.carbon.bpel.util.JsonUtil;
-import org.openo.carbon.bpel.util.Xml2JsonUtil;
-
-import com.codahale.metrics.annotation.Timed;
-import com.fasterxml.jackson.core.JsonParseException;
-import com.fasterxml.jackson.databind.JsonMappingException;
-
-import io.swagger.annotations.Api;
-import io.swagger.annotations.ApiOperation;
-
-@Path("/")
-@Api(tags = {"wso2 bpel api"})
-public class BpsPackage {
-
-  private static final Log log = LogFactory.getLog(BpsPackage.class);
-
-  public static final int STATUS_SUCCESS = 1;
-  public static final int STATUS_FAIL = 0;
-  /**
-   * 无错误
-   */
-  public static final int ERROR_CODE_NOERROR = 0;
-  /**
-   * 不支持的文件类型
-   */
-  public static final int ERROR_CODE_PACKAGE_UNSUPPORED_FILE = 10001;
-  /**
-   * 同名的包正在操作中
-   */
-  public static final int ERROR_CODE_PACKAGE_STATUS_BUSY = 10002;
-  /**
-   * 包名重复
-   */
-  public static final int ERROR_CODE_PACKAGE_DUPLICATED_NAME = 10003;
-  /**
-   * 未获取到包部署的信息
-   */
-  public static final int ERROR_CODE_PACKAGE_DEPLOY_INFORMATION_IS_LOST = 10004;
-  /**
-   * 卸载包失败
-   */
-  public static final int ERROR_CODE_PACKAGE_UNDEPLOY_FAILED = 10005;
-  /**
-   * 包不存在
-   */
-  public static final int ERROR_CODE_PACKAGE_NOTEXISTS = 10006;
-  /**
-   * 服务运行时异常
-   */
-  public static final int ERROR_CODE_RUNTIME_EXCEPTION = 20001;
-  /**
-   * Axis运行时异常
-   */
-  public static final int ERROR_CODE_RUNTIME_EXCEPTION_AXIS = 20002;
-  /**
-   * IO运行时异常
-   */
-  public static final int ERROR_CODE_RUNTIME_EXCEPTION_IO = 20003;
-
-  public static Set<String> packageNameSet = new HashSet<String>();
-
-  private Map<String, String> configMap = null;
-
-  @SuppressWarnings("unused")
-  private final AtomicLong counter;
-
-  public BpsPackage() {
-    this.counter = new AtomicLong();
-  }
-
-  private synchronized String getConfig(String key) {
-    if (configMap == null) {
-      configMap = new HashMap<String, String>();
-      String uploadFilePath = Config.getConfigration().getWso2UploadFilePath();
-      String jksFile = Config.getConfigration().getWso2SslJksFile();
-      String trustStorePassword = Config.getConfigration().getWso2SslJksPassword();
-      String httpUsername = Config.getConfigration().getWso2AuthUserName();
-      String httpPassword = Config.getConfigration().getWso2AuthPassword();
-      String host = Config.getConfigration().getWso2Host();
-      String port = Config.getConfigration().getWso2HostPort();
-      configMap.put("uploadFilePath", uploadFilePath);
-      configMap.put("jksFile", jksFile);
-      configMap.put("trustStorePassword", trustStorePassword);
-      configMap.put("httpUsername", httpUsername);
-      configMap.put("httpPassword", httpPassword);
-      configMap.put("host", host);
-      configMap.put("port", port);
-    }
-    if (configMap.containsKey(key)) {
-      return configMap.get(key);
-    } else {
-      return "";
-    }
-  }
-
-  public static boolean lockPackageName(String packageName) {
-    boolean succeed = false;
-    synchronized (packageNameSet) {
-      if (!packageNameSet.contains(packageName)) {
-        packageNameSet.add(packageName);
-        succeed = true;
-      }
-    }
-    return succeed;
-  }
-
-  public static boolean unlockPackageName(String packageName) {
-    boolean succeed = false;
-    synchronized (packageNameSet) {
-      if (packageNameSet.contains(packageName)) {
-        packageNameSet.remove(packageName);
-        succeed = true;
-      }
-    }
-    return succeed;
-  }
-
-  @POST
-  @Path(value = "package")
-  @Consumes(MediaType.MULTIPART_FORM_DATA)
-  @Produces(value = MediaType.APPLICATION_JSON)
-  @ApiOperation(value = "package process", response = Map.class)
-  @Timed
-  public Map<String, Object> uploadFile(@FormDataParam("filename") String filename,
-      @FormDataParam("file") InputStream fileInputStream,
-      @FormDataParam("file") FormDataContentDisposition fileDetail,
-      @Context HttpServletRequest request, @Context HttpServletResponse response)
-          throws IOException {
-    Map<String, Object> map = new LinkedHashMap<String, Object>();
-    String errorMessage = "unkown";
-    int errorCode = ERROR_CODE_NOERROR;
-
-    String fileName = fileDetail.getFileName();
-    String fullName = getConfig("uploadFilePath") + "/" + fileName;
-    File file = new File(fullName);
-    String packageName = null;
-    try {
-      if (fileName.endsWith(".zip")) {
-        packageName = fileName.substring(0, fileName.length() - 4);
-      } else {
-    	  errorCode = ERROR_CODE_PACKAGE_UNSUPPORED_FILE;
-        throw new Exception("Only support *.zip file.");
-      }
-      if (!lockPackageName(packageName)) {
-    	  errorCode = ERROR_CODE_PACKAGE_STATUS_BUSY;
-        throw new Exception("Package " + packageName + " is operating.");
-      }
-      FileUtils.copyInputStreamToFile(fileInputStream, file);
-      System.setProperty("javax.net.ssl.trustStore", "*.keystore");
-      System.setProperty("java.protocol.handler.pkgs", "com.sun.net.ssl.internal.www.protocol");
-      System.setProperty("javax.net.ssl.trustStore", getConfig("jksFile"));
-      System.setProperty("javax.net.ssl.trustStorePassword", getConfig("trustStorePassword"));
-
-      HttpTransportProperties.Authenticator authenticator =
-          new HttpTransportProperties.Authenticator();
-      List<String> auth = new ArrayList<String>();
-      auth.add(Authenticator.BASIC);
-      authenticator.setAuthSchemes(auth);
-      authenticator.setUsername(getConfig("httpUsername"));
-      authenticator.setPassword(getConfig("httpPassword"));
-      authenticator.setPreemptiveAuthentication(true);
-
-      map.putAll(bpsDeployPackage(fileName, fullName, packageName, authenticator));
-      map.put("status", STATUS_SUCCESS);
-      map.put("message", "success");
-      return map;
-    } catch (AxisFault e) {
-      errorMessage = e.getLocalizedMessage();
-      errorCode = ERROR_CODE_RUNTIME_EXCEPTION_AXIS;
-      log.error(e.getMessage(), e);
-      e.printStackTrace();
-    } catch (IOException e) {
-      errorMessage = e.getLocalizedMessage();
-      errorCode = ERROR_CODE_RUNTIME_EXCEPTION_IO;
-      log.error(e.getMessage(), e);
-      e.printStackTrace();
-    } catch (Throwable e) {
-      errorMessage = e.getLocalizedMessage();
-		if (e instanceof BpsServiceException) {
-			errorCode = ((BpsServiceException) e).getErrorCode();
-		} else {
-			errorCode = ERROR_CODE_RUNTIME_EXCEPTION;
-		}
-      log.error(e.getMessage(), e);
-      e.printStackTrace();
-    } finally {
-      if (packageName != null) {
-        unlockPackageName(packageName);
-      }
-    }
-    map.put("errorCode", errorCode);
-    map.put("status", STATUS_FAIL);
-    map.put("message", errorMessage);
-    return map;
-  }
-
-  @SuppressWarnings("rawtypes")
-  private Map<String, Object> bpsDeployPackage(String fileName, String fullName, String packageName,
-      HttpTransportProperties.Authenticator authenticator)
-          throws JsonParseException, JsonMappingException, IOException, AxisFault, Exception {
-    Map<String, Object> map = new HashMap<String, Object>();
-    Map deployedPackageInfoMap = getDeployedPackageInfo(authenticator, packageName, "");
-    if (deployedPackageInfoMap.get("packageName") != null) {
-      throw new BpsServiceException(ERROR_CODE_PACKAGE_DUPLICATED_NAME,"Package " + deployedPackageInfoMap.get("packageName")
-          + " exist, please undeploy it first.");
-    }
-    OMElement element = deployPackage(fileName, fullName, authenticator);
-    System.out.println(Xml2JsonUtil.xml2JSON(element.toString()));
-
-    long timeout = 60 * 1000L;
-    long timeStart = System.currentTimeMillis();
-    while (System.currentTimeMillis() - timeStart < timeout) {
-      deployedPackageInfoMap = getDeployedPackageInfo(authenticator, packageName, "");
-      if (deployedPackageInfoMap.get("packageName") == null) {
-        Thread.sleep(2000);
-      } else {
-        break;
-      }
-    }
-    if (deployedPackageInfoMap.get("packageName") == null) {
-      throw new BpsServiceException(ERROR_CODE_PACKAGE_DEPLOY_INFORMATION_IS_LOST,
-          "Package " + packageName + " deploy failed or deploy information is lost.");
-    }
-    map.put("packageName", deployedPackageInfoMap.get("packageName"));
-    map.put("processId", deployedPackageInfoMap.get("pid"));
-    return map;
-  }
-
-  private OMElement deployPackage(String fileName, String fullName,
-      HttpTransportProperties.Authenticator authenticator) throws AxisFault {
-    String url =
-        "https://" + getConfig("host") + ":" + getConfig("port") + "/services/BPELUploader?wsdl";
-    RPCServiceClient serviceClient = new RPCServiceClient();
-    EndpointReference targetEPR = new EndpointReference(url);
-    Options options = serviceClient.getOptions();
-    options.setTo(targetEPR);
-    options.setAction("urn:uploadService");
-    options.setProperty(HTTPConstants.SO_TIMEOUT, new Integer(300000));
-    options.setProperty(HTTPConstants.AUTHENTICATE, authenticator);
-    serviceClient.setOptions(options);
-
-    QName qname = new QName("http://services.deployer.bpel.carbon.wso2.org", "uploadService");
-    UploadedFileItem fileItem = new UploadedFileItem();
-    fileItem.setFileName(fileName);
-    fileItem.setFileType("zip");
-
-    DataSource dataSource = new FileDataSource(fullName);
-    fileItem.setDataHandler(new DataHandler(dataSource));
-    UploadedFileItem[] parameters = new UploadedFileItem[] {fileItem};
-    OMElement element = serviceClient.invokeBlocking(qname, parameters);
-    return element;
-  }
-
-  @Path(value = "package/{packageName}")
-  @DELETE
-  @Produces(value = MediaType.APPLICATION_JSON)
-  @ApiOperation(value = "delete", response = Map.class)
-  @Timed
-  public Map<String, Object> delete(@PathParam("packageName") String packageName,
-      @Context HttpServletRequest request) {
-    Map<String, Object> map = new LinkedHashMap<String, Object>();
-    String errorMessage = "unkown";
-    int errorCode = ERROR_CODE_NOERROR;
-    try {
-      if (!lockPackageName(packageName)) {
-        throw new Exception("Package " + packageName + " is operating.");
-      }
-      System.setProperty("javax.net.ssl.trustStore", "*.keystore");
-      System.setProperty("java.protocol.handler.pkgs", "com.sun.net.ssl.internal.www.protocol");
-      System.setProperty("javax.net.ssl.trustStore", getConfig("jksFile"));
-      System.setProperty("javax.net.ssl.trustStorePassword", getConfig("trustStorePassword"));
-
-      HttpTransportProperties.Authenticator authenticator =
-          new HttpTransportProperties.Authenticator();
-      List<String> auth = new ArrayList<String>();
-      auth.add(Authenticator.BASIC);
-      authenticator.setAuthSchemes(auth);
-      authenticator.setUsername(getConfig("httpUsername"));
-      authenticator.setPassword(getConfig("httpPassword"));
-      authenticator.setPreemptiveAuthentication(true);
-
-      map.putAll(bpsUndeployPackage(packageName, authenticator));
-
-      return map;
-    } catch (AxisFault e) {
-      errorMessage = e.getLocalizedMessage();
-      errorCode = ERROR_CODE_RUNTIME_EXCEPTION_AXIS;
-      log.error(e.getMessage(), e);
-      e.printStackTrace();
-    } catch (Throwable e) {
-      errorMessage = e.getLocalizedMessage();
-		if (e instanceof BpsServiceException) {
-			errorCode = ((BpsServiceException) e).getErrorCode();
-		} else {
-			errorCode = ERROR_CODE_RUNTIME_EXCEPTION;
-		}
-      log.error(e.getMessage(), e);
-      e.printStackTrace();
-    } finally {
-      if (packageName != null) {
-        unlockPackageName(packageName);
-      }
-    }
-    map.put("errorCode", errorCode);
-    map.put("status", STATUS_FAIL);
-    map.put("message", errorMessage);
-    return map;
-  }
-
-  @SuppressWarnings({"rawtypes", "unused"})
-  private Map<String, Object> bpsUndeployPackage(String packageName,
-      HttpTransportProperties.Authenticator authenticator)
-          throws JsonParseException, JsonMappingException, IOException, AxisFault, Exception {
-    Map<String, Object> map = new HashMap<String, Object>();
-    Map deployedPackageInfoMap = getDeployedPackageInfo(authenticator, packageName, "");
-    if (deployedPackageInfoMap.get("packageName") == null) {
-      throw new BpsServiceException(ERROR_CODE_PACKAGE_NOTEXISTS,"Package " + deployedPackageInfoMap.get("packageName")
-          + " does not exist, please deploy it first.");
-    }
-    OMElement element = undeployPackage(authenticator, packageName);
-    deployedPackageInfoMap = getDeployedPackageInfo(authenticator, packageName, "");
-    if (deployedPackageInfoMap.get("packageName") != null) {
-      throw new BpsServiceException(ERROR_CODE_PACKAGE_UNDEPLOY_FAILED,
-          "Package " + deployedPackageInfoMap.get("packageName") + " undeploy failed.");
-    }
-    map.put("status", STATUS_SUCCESS);
-    map.put("message", "success");
-
-    return map;
-  }
-
-  private OMElement undeployPackage(HttpTransportProperties.Authenticator authenticator,
-      String packageName) throws AxisFault {
-    String url = "https://" + getConfig("host") + ":" + getConfig("port")
-        + "/services/BPELPackageManagementService?wsdl";
-    RPCServiceClient serviceClient = new RPCServiceClient();
-    EndpointReference targetEPR = new EndpointReference(url);
-    Options options = serviceClient.getOptions();
-    options.setTo(targetEPR);
-    options.setAction("sch:undeployBPELPackage");
-    options.setProperty(HTTPConstants.SO_TIMEOUT, new Integer(300000));
-    options.setProperty(HTTPConstants.AUTHENTICATE, authenticator);
-    serviceClient.setOptions(options);
-    OMFactory fac = OMAbstractFactory.getOMFactory();
-    OMNamespace omNs = fac.createOMNamespace("http://wso2.org/bps/management/schema", "sch");
-    OMElement method = fac.createOMElement("undeployBPELPackage", omNs);
-    OMElement content = fac.createOMElement("package", omNs);
-    content.addChild(fac.createOMText(content, packageName));
-    method.addChild(content);
-    method.build();
-    OMElement res = serviceClient.sendReceive(method);
-    return res;
-  }
-  
-  @SuppressWarnings({"rawtypes", "unchecked"})
-  private Map getFullDeployedPackageInfo(HttpTransportProperties.Authenticator authenticator,
-	      String packageName, String page) throws Exception {
-	    String result;
-	    String jsonTemplate =
-	        "{'listDeployedPackagesPaginated':{'page':'${page}','packageSearchString':'${searchString}'}}";
-	    Map jsonParamMap = new HashMap();
-	    jsonParamMap.put("page", page);
-	    jsonParamMap.put("searchString", packageName);
-	    Object params = getParams(jsonTemplate, jsonParamMap);
-	    result = BpsProcess.invokeWsdl("https://" + getConfig("host") + ":" + getConfig("port")
-	        + "/services/BPELPackageManagementService?wsdl", params, authenticator);
-	    Map<String, Object> processMap = JsonUtil.json2Bean(result, Map.class);
-	    return processMap;
-	  }
-
-  @SuppressWarnings({"rawtypes", "unchecked"})
-  private Map getDeployedPackageInfo(HttpTransportProperties.Authenticator authenticator,
-	      String packageName, String page) throws Exception {
-	    Map resultMap = new HashMap();
-	    Map<String, Object> processMap = getFullDeployedPackageInfo(authenticator, packageName, page);
-	    Object packages = ((Map) processMap.get("deployedPackagesPaginated")).get("package");
-	    Map deployedPackage = null;
-	    if (packages instanceof List) {
-	      for (Iterator iter = ((List) packages).iterator(); iter.hasNext();) {
-	        Map packageMap = (Map) iter.next();
-	        String deployedPackageName = (String) packageMap.get("name");
-	        if (deployedPackageName.equals(packageName)) {
-	          deployedPackage = packageMap;
-	          break;
-	        }
-	      }
-	    } else if (packages instanceof Map) {
-	      String deployedPackageName = (String) ((Map) packages).get("name");
-	      if (deployedPackageName.equals(packageName)) {
-	        deployedPackage = (Map) packages;
-	      }
-	    }
-	    if (deployedPackage != null) {
-	      String fullPackageName = null;
-	      String pid = null;
-	      Object versions = ((Map) deployedPackage.get("versions")).get("version");
-	      Map lastestVersion = null;
-	      if (versions instanceof List) {
-	        for (Iterator iter = ((List) versions).iterator(); iter.hasNext();) {
-	          Map version = (Map) iter.next();
-	          if (version.get("isLatest").equals("true")) {
-	            lastestVersion = version;
-	          }
-	        }
-	      } else if (versions instanceof Map) {
-	        lastestVersion = (Map) versions;
-	      }
-	      fullPackageName = (String) ((Map) ((Map) lastestVersion.get("processes")).get("process"))
-	          .get("packageName");
-	      pid = (String) ((Map) ((Map) lastestVersion.get("processes")).get("process")).get("pid");
-	      resultMap.put("packageName", fullPackageName);
-	      resultMap.put("pid", pid);
-	    }
-	    return resultMap;
-}
-
-
-  @SuppressWarnings({"rawtypes", "unchecked"})
-  public static Map<String, Object> getParams(String jsonTemplate, Map<String, Object> paramMap)
-      throws JsonParseException, JsonMappingException, IOException {
-    String json = jsonTemplate.replaceAll("'", "\"");
-		for (Iterator iter = paramMap.keySet().iterator(); iter.hasNext();) {
-			String key = (String) iter.next();
-			String value = "";
-			if (paramMap.get(key) != null) {
-				value = paramMap.get(key).toString().replaceAll("\"", "\\\\\"");
-			}
-			json = json.replaceAll("\\$\\{" + key + "\\}", value);
-		}
-    return JsonUtil.json2Bean(json, Map.class);
-  }
-  
-  @GET
-  @Path(value = "listPackages")
-  @Produces(value = MediaType.APPLICATION_JSON)
-  @ApiOperation(value = "list packages", response = Map.class)
-  @Timed
-  public Map<String, Object> listPackages(@QueryParam("page") String page,
-	      @QueryParam("searchString") String searchString, @Context HttpServletRequest request)
-          throws IOException {
-    Map<String, Object> map = new LinkedHashMap<String, Object>();
-    String errorMessage = "unkown";
-    int errorCode = ERROR_CODE_NOERROR;
-    String packageName = null;
-    try {
-      System.setProperty("javax.net.ssl.trustStore", "*.keystore");
-      System.setProperty("java.protocol.handler.pkgs", "com.sun.net.ssl.internal.www.protocol");
-      System.setProperty("javax.net.ssl.trustStore", getConfig("jksFile"));
-      System.setProperty("javax.net.ssl.trustStorePassword", getConfig("trustStorePassword"));
-
-      HttpTransportProperties.Authenticator authenticator =
-          new HttpTransportProperties.Authenticator();
-      List<String> auth = new ArrayList<String>();
-      auth.add(Authenticator.BASIC);
-      authenticator.setAuthSchemes(auth);
-      authenticator.setUsername(getConfig("httpUsername"));
-      authenticator.setPassword(getConfig("httpPassword"));
-      authenticator.setPreemptiveAuthentication(true);
-
-      map.putAll(getFullDeployedPackageInfo(authenticator,searchString,page));
-
-      map.put("status", STATUS_SUCCESS);
-      map.put("message", "success");
-      return map;
-    } catch (AxisFault e) {
-      errorMessage = e.getLocalizedMessage();
-      errorCode = ERROR_CODE_RUNTIME_EXCEPTION_AXIS;
-      log.error(e.getMessage(), e);
-      e.printStackTrace();
-    } catch (IOException e) {
-      errorMessage = e.getLocalizedMessage();
-      errorCode = ERROR_CODE_RUNTIME_EXCEPTION_IO;
-      log.error(e.getMessage(), e);
-      e.printStackTrace();
-    } catch (Throwable e) {
-			if (e instanceof BpsServiceException) {
-				errorCode = ((BpsServiceException) e).getErrorCode();
-			} else {
-				errorCode = ERROR_CODE_RUNTIME_EXCEPTION;
-			}
-      errorMessage = e.getLocalizedMessage();
-      log.error(e.getMessage(), e);
-      e.printStackTrace();
-    } finally {
-      if (packageName != null) {
-        unlockPackageName(packageName);
-      }
-    }
-    map.put("errorCode", errorCode);
-    map.put("status", STATUS_FAIL);
-    map.put("message", errorMessage);
-    return map;
-  }
-
-  @SuppressWarnings("rawtypes")
-  public static void main(String[] args) {
-    try {
-
-      boolean remoteDebug = true;
-      boolean localDebug = false;
-      if (remoteDebug) {
-        Client client = ClientBuilder.newBuilder().register(MultiPartFeature.class).build();
-        WebTarget target = client.target("http://localhost:8101/openoapi/wso2bpel/v1/package");
-        FileDataBodyPart bodyPart = new FileDataBodyPart("file",
-            new File("F:\\wso2bps-3.5.1\\wso2bps-3.5.1\\repository\\samples\\bpel\\Alarm.zip"));
-        FormDataMultiPart formDataMultiPart = new FormDataMultiPart();
-        formDataMultiPart.field("fileName", "Alarm.zip").bodyPart(bodyPart);
-        String result = target.request(MediaType.APPLICATION_JSON)
-            .post(Entity.entity(formDataMultiPart, formDataMultiPart.getMediaType()), String.class);
-        System.out.println(result);
-      }
-      //
-      // System.out.println("************************************************************************");
-      //
-      // bodyPart = new FileDataBodyPart("file", new
-      // File("D:\\temp\\bpel-sample\\AssignDate\\AssignDate.zip"));
-      // formDataMultiPart = new FormDataMultiPart();
-      // formDataMultiPart.field("fileName",
-      // "AssignDate.zip").bodyPart(bodyPart);
-      // result = target.request(MediaType.APPLICATION_JSON)
-      // .post(Entity.entity(formDataMultiPart,
-      // formDataMultiPart.getMediaType()), String.class);
-      // System.out.println(result);
-      //
-      if (localDebug) {
-        System.setProperty("javax.net.ssl.trustStore", "*.keystore");
-        System.setProperty("java.protocol.handler.pkgs", "com.sun.net.ssl.internal.www.protocol");
-        System.setProperty("javax.net.ssl.trustStore",
-            "D:\\software\\WSO2\\wso2bps-3.5.1\\repository\\resources\\security\\wso2carbon.jks");
-        System.setProperty("javax.net.ssl.trustStorePassword", "wso2carbon");
-        HttpTransportProperties.Authenticator authenticator =
-            new HttpTransportProperties.Authenticator();
-        List<String> auth = new ArrayList<String>();
-        auth.add(Authenticator.BASIC);
-        authenticator.setAuthSchemes(auth);
-        authenticator.setUsername("admin");
-        authenticator.setPassword("admin");
-        authenticator.setPreemptiveAuthentication(true);
-        //
-        // String packageName = "RESTProcess";
-        // Map deployedPackageInfoMap =
-        // getDeployedPackageInfo(authenticator, packageName);
-
-        BpsPackage packageTest = new BpsPackage();
-        Map map;
-        // map = packageTest.bpsUndeployPackage("AssignDate",
-        // authenticator);
-        // System.out.println(JsonUtil.bean2Json(map));
-        map = packageTest.bpsDeployPackage("AssignDate.zip",
-            "D:\\temp\\bpel-sample\\AssignDate\\AssignDate.zip", "AssignDate", authenticator);
-        System.out.println(JsonUtil.bean2Json(map));
-        map = packageTest.bpsUndeployPackage("AssignDate", authenticator);
-        System.out.println(JsonUtil.bean2Json(map));
-      }
-
-    } catch (Exception e) {
-      e.printStackTrace();
-    }
-  }
-}