1 # Copyright (c) 2019, CMCC Technologies. Co., Ltd.
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
7 # http://www.apache.org/licenses/LICENSE-2.0
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.
18 from coverage.xmlreport import os
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
28 logger = logging.getLogger(__name__)
31 class ServicePackage(object):
33 Actions for sdc service package.
39 def on_distribute(self, csar_id):
41 Get service packge from SDC and process
45 if ServicePackageModel.objects.filter(servicePackageId=csar_id):
46 err_msg = "Service CSAR(%s) already exists." % csar_id
48 raise PackageHasExistsException("Service CSAR(%s) already exists." % csar_id)
51 service = sdc.get_asset(sdc.ASSETTYPE_SERVICES, csar_id)
52 # check if the related resources exist
53 resources = service.get('resources', None)
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'])
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, "")
70 serviced = ServiceDescriptor()
71 serviced.create(data, csar_id)
72 serviced.parse_serviced_and_save(csar_id, local_file_name)
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)
80 def delete_csar(self, csar_id):
82 Delete service package
86 serviced = ServiceDescriptor()
87 serviced.delete_single(csar_id)
91 Get service packages from DB
95 packages = ServicePackageModel.objects.filter()
96 for package in packages:
97 csar = self.get_csar(package.servicePackageId)
101 def get_csar(self, csar_id):
103 Get a service package by id
108 csars = ServicePackageModel.objects.filter(servicePackageId=csar_id)
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"],
122 csars[0].servicePackageUri)
124 error_message = "Service package[%s] not Found." % csar_id
125 logger.error(error_message)
126 raise PackageNotFoundException(error_message)
128 return {"csarId": csar_id, "packageInfo": package_info}
130 def parse_serviced(self, csar_id, inputs):
132 Parse service package
137 service_pkg = ServicePackageModel.objects.filter(servicePackageId=csar_id)
139 raise PackageNotFoundException("Service CSAR(%s) does not exist." % csar_id)
142 csar_path = service_pkg[0].localFilePath
143 ret = {"model": toscaparser.parse_sd(csar_path, inputs)}
145 except CatalogException as e:
146 logger.error(e.args[0])
148 except Exception as e:
149 logger.error(e.args[0])
150 logger.error(traceback.format_exc())