1 # Copyright 2017 ZTE Corporation.
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.
22 from catalog.pub.database.models import NSDModel, NfPackageModel
23 from catalog.pub.utils.values import ignore_case_get
24 from catalog.pub.exceptions import CatalogException
25 from catalog.pub.msapi import sdc
26 from catalog.pub.config.config import CATALOG_ROOT_PATH
27 from catalog.pub.utils import toscaparser
28 from catalog.pub.utils import fileutil
29 from catalog.pub.msapi import nfvolcm
31 logger = logging.getLogger(__name__)
33 STATUS_SUCCESS, STATUS_FAILED = "success", "failed"
36 def fmt_ns_pkg_rsp(status, desc, error_code="500"):
37 return [0, {"status": status, "statusDescription": desc, "errorCode": error_code}]
40 def ns_on_distribute(csar_id):
43 ret = NsPackage().on_distribute(csar_id)
44 except CatalogException as e:
45 NsPackage().delete_catalog(csar_id)
46 return fmt_ns_pkg_rsp(STATUS_FAILED, e.message)
48 logger.error(traceback.format_exc())
49 NsPackage().delete_catalog(csar_id)
50 return fmt_ns_pkg_rsp(STATUS_FAILED, str(sys.exc_info()))
51 return fmt_ns_pkg_rsp(STATUS_SUCCESS, ret[1], "")
54 def ns_delete_csar(csar_id, force_delete):
57 ret = NsPackage().delete_csar(csar_id, force_delete)
58 except CatalogException as e:
59 return fmt_ns_pkg_rsp(STATUS_FAILED, e.message)
61 logger.error(traceback.format_exc())
62 return fmt_ns_pkg_rsp(STATUS_FAILED, str(sys.exc_info()))
63 return fmt_ns_pkg_rsp(STATUS_SUCCESS, ret[1], "")
68 ret = NsPackage().get_csars()
69 except CatalogException as e:
72 logger.error(traceback.format_exc())
73 return [1, str(sys.exc_info())]
76 def ns_get_csar(csar_id):
79 ret = NsPackage().get_csar(csar_id)
80 except CatalogException as e:
83 logger.error(traceback.format_exc())
84 return [1, str(sys.exc_info())]
87 def parser_nsdmodel(csar_id,inputs):
90 nf_pkg = NSDModel.objects.filter(id=csar_id)
95 csar_path = os.path.join(os.path.dirname(__file__), pkg.nsd_path)
100 ret={"model":toscaparser.parse_nsd(csar_path,inputs)}
101 except CatalogException as e:
102 return [1, e.message]
104 logger.error(traceback.format_exc())
105 return [1, str(sys.exc_info())]
108 ###############################################################################################################
110 class NsPackage(object):
112 Actions for sdc ns package.
118 def on_distribute(self, csar_id):
119 if NSDModel.objects.filter(id=csar_id):
120 raise CatalogException("NS CSAR(%s) already exists." % csar_id)
122 nsd,local_file_name,nsd_json = self.get_nsd(csar_id)
124 nsd_id = nsd["metadata"]["id"]
125 if NSDModel.objects.filter(nsd_id=nsd_id):
126 raise CatalogException("NSD(%s) already exists." % nsd_id)
128 for vnf in nsd["vnfs"]:
129 vnfd_id = vnf["properties"]["id"]
130 pkg = NfPackageModel.objects.filter(vnfdid=vnfd_id)
132 raise CatalogException("VNF package(%s) is not distributed." % vnfd_id)
137 name=nsd["metadata"].get("name", nsd_id),
138 vendor=nsd["metadata"].get("vendor", "undefined"),
139 description=nsd["metadata"].get("description", ""),
140 version=nsd["metadata"].get("version", "undefined"),
141 nsd_path=local_file_name,
142 nsd_model=nsd_json).save()
144 return [0, "CSAR(%s) distributed successfully." % csar_id]
146 def get_nsd(self, csar_id):
147 artifact = sdc.get_artifact(sdc.ASSETTYPE_SERVICES, csar_id)
148 local_path = os.path.join(CATALOG_ROOT_PATH, csar_id)
149 local_file_name = sdc.download_artifacts(artifact["toscaModelURL"], local_path)
151 nsd_json = toscaparser.parse_nsd(local_file_name)
152 nsd = json.JSONDecoder().decode(nsd_json)
154 return nsd,local_file_name,nsd_json
156 def delete_csar(self, csar_id, force_delete):
159 NSInstModel.objects.filter(nspackage_id=csar_id).delete()
161 if NSInstModel.objects.filter(nspackage_id=csar_id):
162 raise CatalogException("CSAR(%s) is in using, cannot be deleted." % csar_id)
164 nfvolcm.delete_ns_inst_mock()
165 NSDModel.objects.filter(id=csar_id).delete()
166 return [0, "Delete CSAR(%s) successfully." % csar_id]
171 nss = NSDModel.objects.filter()
179 def get_csar(self, csar_id):
181 csars = NSDModel.objects.filter(id=csar_id)
183 package_info["nsdId"] = csars[0].nsd_id
184 package_info["nsdProvider"] = csars[0].vendor
185 package_info["nsdVersion"] = csars[0].version
187 #nss = NSInstModel.objects.filter(nspackage_id=csar_id)
188 nss = nfvolcm.getNsInsts_mock()
189 ns_instance_info = [{
190 "nsInstanceId": ns["nsInstanceId"],
191 "nsInstanceName": ns["nsInstanceName"]} for ns in nss]
193 return [0, {"csarId": csar_id,
194 "packageInfo": package_info,
195 "nsInstanceInfo": ns_instance_info}]
197 def delete_catalog(self, csar_id):
198 local_path = os.path.join(CATALOG_ROOT_PATH, csar_id)
199 fileutil.delete_dirs(local_path)