catalog/packages/biz/sdc_service_package.py

   1 # Copyright (c) 2019, CMCC Technologies. Co., Ltd.
   2 #
   3 # Licensed under the Apache License, Version 2.0 (the "License");
   4 # you may not use this file except in compliance with the License.
   5 # You may obtain a copy of the License at
   6 #
   7 #         http://www.apache.org/licenses/LICENSE-2.0
   8 #
   9 # Unless required by applicable law or agreed to in writing, software
  10 # distributed under the License is distributed on an "AS IS" BASIS,
  11 # WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  12 # See the License for the specific language governing permissions and
  13 # limitations under the License.
  14
  15 import logging
  16 import traceback
  17
  18 from coverage.xmlreport import os
  19
  20 from catalog.packages.biz.service_descriptor import ServiceDescriptor
  21 from catalog.pub.config.config import CATALOG_ROOT_PATH, REG_TO_MSB_REG_PARAM, CATALOG_URL_PATH
  22 from catalog.pub.database.models import ServicePackageModel, VnfPackageModel, PnfPackageModel
  23 from catalog.pub.exceptions import CatalogException, PackageNotFoundException, \
  24     PackageHasExistsException
  25 from catalog.pub.msapi import sdc
  26 from catalog.pub.utils import fileutil, toscaparser
  27
  28 logger = logging.getLogger(__name__)
  29
  30
  31 class ServicePackage(object):
  32     """
  33     Actions for sdc service package.
  34     """
  35
  36     def __init__(self):
  37         pass
  38
  39     def on_distribute(self, csar_id):
  40         """
  41         Get service packge from SDC and process
  42         :param csar_id:
  43         :return:
  44         """
  45         if ServicePackageModel.objects.filter(servicePackageId=csar_id):
  46             err_msg = "Service CSAR(%s) already exists." % csar_id
  47             logger.warn(err_msg)
  48             raise PackageHasExistsException("Service CSAR(%s) already exists." % csar_id)
  49
  50         try:
  51             service = sdc.get_asset(sdc.ASSETTYPE_SERVICES, csar_id)
  52             # check if the related resources exist
  53             resources = service.get('resources', None)
  54             if resources:
  55                 for resource in resources:
  56                     if not VnfPackageModel.objects.filter(vnfPackageId=resource['resourceUUID']) and \
  57                             not PnfPackageModel.objects.filter(pnfPackageId=resource['resourceUUID']):
  58                         logger.error("Resource [%s] is not distributed.", resource['resourceUUID'])
  59                         raise CatalogException("Resource (%s) is not distributed." % resource['resourceUUID'])
  60
  61             # download csar package
  62             local_path = os.path.join(CATALOG_ROOT_PATH, csar_id)
  63             csar_name = "%s.csar" % service.get("name", csar_id)
  64             local_file_name = sdc.download_artifacts(service["toscaModelURL"], local_path, csar_name)
  65             if local_file_name.endswith(".csar") or local_file_name.endswith(".zip"):
  66                 fileutil.unzip_file(local_file_name, local_path, "")
  67             data = {
  68                 'userDefinedData': {}
  69             }
  70             serviced = ServiceDescriptor()
  71             serviced.create(data, csar_id)
  72             serviced.parse_serviced_and_save(csar_id, local_file_name)
  73
  74         except Exception as e:
  75             logger.error(traceback.format_exc())
  76             if ServicePackageModel.objects.filter(servicePackageId=csar_id):
  77                 ServicePackage().delete_csar(csar_id)
  78             raise e
  79
  80     def delete_csar(self, csar_id):
  81         """
  82         Delete service package
  83         :param csar_id:
  84         :return:
  85         """
  86         serviced = ServiceDescriptor()
  87         serviced.delete_single(csar_id)
  88
  89     def get_csars(self):
  90         """
  91         Get service packages from DB
  92         :return:
  93         """
  94         csars = []
  95         packages = ServicePackageModel.objects.filter()
  96         for package in packages:
  97             csar = self.get_csar(package.servicePackageId)
  98             csars.append(csar)
  99         return csars
 100
 101     def get_csar(self, csar_id):
 102         """
 103         Get a service package by id
 104         :param csar_id:
 105         :return:
 106         """
 107         package_info = {}
 108         csars = ServicePackageModel.objects.filter(servicePackageId=csar_id)
 109         if csars:
 110             package_info["servicedId"] = csars[0].servicedId
 111             package_info["servicePackageId"] = csars[0].servicePackageId
 112             package_info["servicedProvider"] = csars[0].servicedDesigner
 113             package_info["servicedVersion"] = csars[0].servicedVersion
 114             package_info["csarName"] = csars[0].servicePackageUri
 115             package_info["servicedModel"] = csars[0].servicedModel
 116             package_info["servicedInvariantId"] = csars[0].invariantId
 117             package_info["downloadUrl"] = "http://%s:%s/%s/%s/%s" % (
 118                 REG_TO_MSB_REG_PARAM[0]["nodes"][0]["ip"],
 119                 REG_TO_MSB_REG_PARAM[0]["nodes"][0]["port"],
 120                 CATALOG_URL_PATH,
 121                 csar_id,
 122                 csars[0].servicePackageUri)
 123         else:
 124             error_message = "Service package[%s] not Found." % csar_id
 125             logger.error(error_message)
 126             raise PackageNotFoundException(error_message)
 127
 128         return {"csarId": csar_id, "packageInfo": package_info}
 129
 130     def parse_serviced(self, csar_id, inputs):
 131         """
 132         Parse service package
 133         :param csar_id:
 134         :param inputs:
 135         :return:
 136         """
 137         service_pkg = ServicePackageModel.objects.filter(servicePackageId=csar_id)
 138         if not service_pkg:
 139             raise PackageNotFoundException("Service CSAR(%s) does not exist." % csar_id)
 140
 141         try:
 142             csar_path = service_pkg[0].localFilePath
 143             ret = {"model": toscaparser.parse_sd(csar_path, inputs)}
 144             return ret
 145         except CatalogException as e:
 146             logger.error(e.args[0])
 147             raise e
 148         except Exception as e:
 149             logger.error(e.args[0])
 150             logger.error(traceback.format_exc())
 151             raise e