[vfc/nfvo/catalog.git] /

/**\r
 * Copyright 2016 [ZTE] and others.\r
 *\r
 * Licensed under the Apache License, Version 2.0 (the "License");\r
 * you may not use this file except in compliance with the License.\r
 * You may obtain a copy of the License at\r
 *\r
 *     http://www.apache.org/licenses/LICENSE-2.0\r
 *\r
 * Unless required by applicable law or agreed to in writing, software\r
 * distributed under the License is distributed on an "AS IS" BASIS,\r
 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.\r
 * See the License for the specific language governing permissions and\r
 * limitations under the License.\r
 */\r
\r
package org.openo.commontosca.catalog.model.plan.wso2;\r
\r
import com.google.gson.Gson;\r
\r
import com.eclipsesource.jaxrs.consumer.ConsumerFactory;\r
\r
import org.apache.http.HttpEntity;\r
import org.apache.http.entity.ContentType;\r
import org.apache.http.entity.mime.MultipartEntityBuilder;\r
import org.glassfish.jersey.client.ClientConfig;\r
import org.openo.commontosca.catalog.common.Config;\r
import org.openo.commontosca.catalog.db.exception.CatalogResourceException;\r
import org.openo.commontosca.catalog.model.plan.wso2.entity.DeletePackageResponse;\r
import org.openo.commontosca.catalog.model.plan.wso2.entity.DeployPackageResponse;\r
import org.openo.commontosca.catalog.model.plan.wso2.entity.StartProcessRequest;\r
import org.openo.commontosca.catalog.model.plan.wso2.entity.StartProcessResponse;\r
import org.slf4j.Logger;\r
import org.slf4j.LoggerFactory;\r
\r
import java.io.BufferedInputStream;\r
import java.io.File;\r
import java.io.FileInputStream;\r
import java.io.FileNotFoundException;\r
import java.io.IOException;\r
import java.io.InputStream;\r
import java.util.Map;\r
import java.util.zip.ZipEntry;\r
import java.util.zip.ZipFile;\r
import java.util.zip.ZipInputStream;\r
\r
\r
\r
public class Wso2ServiceConsumer {\r
  public static final String WSO2_APP_URL = "/openoapi/wso2bpel/v1/package";\r
  private static final Logger LOGGER = LoggerFactory.getLogger(Wso2ServiceConsumer.class);\r
  \r
  /**\r
   * deploy package.\r
   * @param zipFileLocation zip file location\r
   * @param planFilePath plan file path\r
   * @return DeployPackageResponse\r
   * @throws CatalogResourceException e1\r
   */\r
  public static DeployPackageResponse deployPackage(String zipFileLocation, String planFilePath)\r
      throws CatalogResourceException {\r
    InputStream ins = null;\r
    try {\r
      ins = getInputStream(zipFileLocation, planFilePath);\r
      RestResponse res = RestfulClient.post(Config.getConfigration().getWso2HostIp(),\r
          Integer.parseInt(Config.getConfigration().getWso2HostPort()), WSO2_APP_URL,\r
          buildRequest(ins, planFilePath));\r
\r
      if (res.getStatusCode() == null || res.getResult() == null) {\r
        throw new CatalogResourceException(\r
            "Deploy Package return null. Response = " + res);\r
      }\r
      \r
      if (200 == res.getStatusCode() || 201 == res.getStatusCode()) {\r
        DeployPackageResponse response =\r
            new Gson().fromJson(res.getResult(), DeployPackageResponse.class);\r
        if (response.isSuccess()) {\r
          return response;\r
        }\r
      }\r
\r
      throw new CatalogResourceException(\r
          "Deploy Package return fail. Response = " + res.getResult());\r
    } catch (FileNotFoundException e1) {\r
      throw new CatalogResourceException("Deploy Package failed.", e1);\r
    } finally {\r
      if (ins != null) {\r
        try {\r
          ins.close();\r
        } catch (IOException e1) {\r
          LOGGER.error("inputStream close failed !");\r
        }\r
      }\r
    }\r
  }\r
\r
  private static HttpEntity buildRequest(InputStream inputStream, String filePath)\r
      throws FileNotFoundException {\r
    MultipartEntityBuilder builder = MultipartEntityBuilder.create();\r
    builder.seContentType(ContentType.MULTIPART_FORM_DATA);\r
    builder.addBinaryBody("file", inputStream, ContentType.APPLICATION_OCTET_STREAM,\r
        new File(filePath).getName());\r
    return builder.build();\r
  }\r
\r
  @SuppressWarnings("resource")\r
  private static InputStream getInputStream(String zipFileLocation, String planFilePath)\r
      throws CatalogResourceException {\r
    ZipInputStream zin = null;\r
    try {\r
      InputStream in = new BufferedInputStream(new FileInputStream(zipFileLocation));\r
      zin = new ZipInputStream(in);\r
      ZipEntry ze;\r
      while ((ze = zin.getNextEntry()) != null) {\r
        if (planFilePath.equals(ze.getName())) {\r
          ZipFile zf = new ZipFile(zipFileLocation);\r
          return zf.getInputStream(ze);\r
        }\r
      }\r
    } catch (IOException e1) {\r
      throw new CatalogResourceException("Get InputStream failed. planFilePath = " + planFilePath,\r
          e1);\r
    } finally {\r
      closeStream(zin);\r
    }\r
\r
    throw new CatalogResourceException("Get InputStream failed. planFilePath = " + planFilePath);\r
  }\r
\r
  private static void closeStream(ZipInputStream zin) {\r
\r
    if (zin != null) {\r
      try {\r
        zin.closeEntry();\r
      } catch (IOException e1) {\r
        LOGGER.error("zip inputStream close failed !");\r
      }\r
    }\r
  }\r
\r
  /**\r
   * delet package.\r
   * @param packageName package to delete according packageName\r
   * @return DeletePackageResponse\r
   * @throws CatalogResourceException e1\r
   */\r
  public static DeletePackageResponse deletePackage(String packageName)\r
      throws CatalogResourceException {\r
    try {\r
      ClientConfig config = new ClientConfig();\r
      Iwso2RestService wso2Proxy = ConsumerFactory.createConsumer(\r
          Config.getConfigration().getWso2BaseUrl(), config, Iwso2RestService.class);\r
      DeletePackageResponse response = wso2Proxy.deletePackage(packageName);\r
      if (response.isSuccess()) {\r
        return response;\r
      }\r
      throw new CatalogResourceException(response.getException());\r
    } catch (Exception e1) {\r
      throw new CatalogResourceException(\r
          "Call Delete Package api failed. packageName = " + packageName, e1);\r
    }\r
  }\r
\r
\r
  /**\r
   * start process.\r
   * @param processId process id\r
   * @param params params\r
   * @return StartProcessResponse\r
   * @throws CatalogResourceException e1\r
   */\r
  public static StartProcessResponse startProcess(String processId, Map<String, Object> params)\r
      throws CatalogResourceException {\r
    try {\r
      ClientConfig config = new ClientConfig();\r
      Iwso2RestService wso2Proxy = ConsumerFactory.createConsumer(\r
          Config.getConfigration().getWso2BaseUrl(), config, Iwso2RestService.class);\r
      StartProcessResponse response =\r
          wso2Proxy.startProcess(new StartProcessRequest(processId, params));\r
      if (response.isSuccess()) {\r
        return response;\r
      }\r
      throw new CatalogResourceException(response.getException());\r
    } catch (Exception e1) {\r
      throw new CatalogResourceException("Call Start Process api failed.", e1);\r
    }\r
  }\r
\r
}\r