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.
20 from genericparser.pub.config.config import GENERICPARSER_ROOT_PATH, GENERICPARSER_URL_PATH
21 from genericparser.pub.config.config import REG_TO_MSB_REG_PARAM
22 from genericparser.pub.database.models import NSPackageModel
23 from genericparser.pub.exceptions import GenericparserException
24 from genericparser.pub.msapi import sdc
25 from genericparser.pub.utils import toscaparsers
26 from genericparser.packages.biz.ns_descriptor import NsDescriptor
27 from genericparser.pub.utils import fileutil
29 logger = logging.getLogger(__name__)
31 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 GenericparserException as e:
45 NsPackage().delete_csar(csar_id)
46 return fmt_ns_pkg_rsp(STATUS_FAILED, e.args[0])
48 logger.error(traceback.format_exc())
49 NsPackage().delete_csar(csar_id)
50 return fmt_ns_pkg_rsp(STATUS_FAILED, str(sys.exc_info()))
52 return fmt_ns_pkg_rsp(STATUS_FAILED, ret[1])
53 return fmt_ns_pkg_rsp(STATUS_SUCCESS, ret[1], "")
56 def ns_delete_csar(csar_id):
59 ret = NsPackage().delete_csar(csar_id)
60 except GenericparserException as e:
61 return fmt_ns_pkg_rsp(STATUS_FAILED, e.args[0])
63 logger.error(traceback.format_exc())
64 return fmt_ns_pkg_rsp(STATUS_FAILED, str(sys.exc_info()))
65 return fmt_ns_pkg_rsp(STATUS_SUCCESS, ret[1], "")
71 ret = NsPackage().get_csars()
72 except GenericparserException as e:
75 logger.error(traceback.format_exc())
76 return [1, str(sys.exc_info())]
80 def ns_get_csar(csar_id):
83 ret = NsPackage().get_csar(csar_id)
84 except GenericparserException as e:
86 except Exception as e:
87 logger.error(e.args[0])
88 logger.error(traceback.format_exc())
89 return [1, str(sys.exc_info())]
93 def parse_nsd(csar_id, inputs):
96 ns_pkg = NSPackageModel.objects.filter(nsPackageId=csar_id)
98 raise GenericparserException("NS CSAR(%s) does not exist." % csar_id)
99 csar_path = ns_pkg[0].localFilePath
100 ret = {"model": toscaparsers.parse_nsd(csar_path, inputs)}
101 except GenericparserException as e:
102 return [1, e.args[0]]
103 except Exception as e:
104 logger.error(e.args[0])
105 logger.error(traceback.format_exc())
106 return [1, str(sys.exc_info())]
110 class NsPackage(object):
112 Actions for sdc ns package.
118 def on_distribute(self, csar_id):
119 if NSPackageModel.objects.filter(nsPackageId=csar_id):
120 return [1, "NS CSAR(%s) already exists." % csar_id]
122 artifact = sdc.get_artifact(sdc.ASSETTYPE_SERVICES, csar_id)
123 local_path = os.path.join(GENERICPARSER_ROOT_PATH, csar_id)
124 csar_name = "%s.csar" % artifact.get("name", csar_id)
125 local_file_name = sdc.download_artifacts(artifact["toscaModelURL"], local_path, csar_name)
126 if local_file_name.endswith(".csar") or local_file_name.endswith(".zip"):
127 artifact_vnf_file = fileutil.unzip_file(local_file_name, local_path, "Artifacts/Deployment/OTHER/ns.csar")
128 if os.path.exists(artifact_vnf_file):
129 local_file_name = artifact_vnf_file
132 'userDefinedData': {}
135 nsd.create(data, csar_id)
136 nsd.parse_nsd_and_save(csar_id, local_file_name)
137 return [0, "CSAR(%s) distributed successfully." % csar_id]
139 def delete_csar(self, csar_id):
141 nsd.delete_single(csar_id)
142 return [0, "Delete CSAR(%s) successfully." % csar_id]
146 nss = NSPackageModel.objects.filter()
148 ret = self.get_csar(ns.nsPackageId)
152 def get_csar(self, csar_id):
154 csars = NSPackageModel.objects.filter(nsPackageId=csar_id)
156 package_info["nsdId"] = csars[0].nsdId
157 package_info["nsPackageId"] = csars[0].nsPackageId
158 package_info["nsdProvider"] = csars[0].nsdDesginer
159 package_info["nsdVersion"] = csars[0].nsdVersion
160 package_info["csarName"] = csars[0].nsPackageUri
161 package_info["nsdModel"] = csars[0].nsdModel
162 package_info["nsdInvariantId"] = csars[0].invariantId
163 package_info["downloadUrl"] = "http://%s:%s/%s/%s/%s" % (
164 REG_TO_MSB_REG_PARAM[0]["nodes"][0]["ip"],
165 REG_TO_MSB_REG_PARAM[0]["nodes"][0]["port"],
166 GENERICPARSER_URL_PATH,
168 csars[0].nsPackageUri)
170 raise GenericparserException("Ns package[%s] not Found." % csar_id)
172 return [0, {"csarId": csar_id, "packageInfo": package_info}]