Fix bugs of parse nsd/vnfd api 17/13417/1
authorfujinhua <fu.jinhua@zte.com.cn>
Tue, 19 Sep 2017 11:01:41 +0000 (19:01 +0800)
committerfujinhua <fu.jinhua@zte.com.cn>
Tue, 19 Sep 2017 11:01:41 +0000 (19:01 +0800)
Fix bugs of db records get logic

Change-Id: I17ff3ff6b68ceb99fd860619674b979249002265
Issue-Id: VFC-388
Signed-off-by: fujinhua <fu.jinhua@zte.com.cn>
catalog/packages/nf_package.py
catalog/packages/ns_package.py
catalog/packages/views.py

index ae8d901..b07c583 100644 (file)
@@ -54,19 +54,19 @@ def nf_get_csar(csar_id):
         return [1, str(sys.exc_info())]
     return ret
 
-def parser_vnfdmodel(csar_id,inputs):
+def parse_vnfd(csar_id, inputs):
     ret= None
     try:
         nf_pkg = VnfPackageModel.objects.filter(vnfPackageId=csar_id)
         if nf_pkg:
-             csar_path=nf_pkg["localFilePath"]
-             ret={"model":toscaparser.parse_vnfd(csar_path,inputs)}
+             csar_path = nf_pkg[0].localFilePath
+             ret = {"model": toscaparser.parse_vnfd(csar_path, inputs)}
     except CatalogException as e:
         return [1, e.message]
     except:
         logger.error(traceback.format_exc())
         return [1, str(sys.exc_info())]
-    return [0,ret]
+    return [0, ret]
 
 
 class NfDistributeThread(threading.Thread):
index 90e330d..a5ee049 100644 (file)
@@ -92,22 +92,19 @@ def ns_get_csar(csar_id):
         return [1, str(sys.exc_info())]
     return ret
 
-def parser_NSPackageModel(csar_id,inputs):
+def parse_nsd(csar_id, inputs):
     ret= None
     try:
-        nf_pkg = NSPackageModel.objects.filter(nsPackageId=csar_id)
-
-        if nf_pkg:
-            for pkg in nf_pkg:
-                csar_path = pkg.localFilePath
-                ret={"model":toscaparser.parse_nsd(csar_path,inputs)}
-                continue
+        ns_pkg = NSPackageModel.objects.filter(nsPackageId=csar_id)
+        if ns_pkg:
+            csar_path = ns_pkg[0].localFilePath
+            ret = {"model": toscaparser.parse_nsd(csar_path, inputs)}
     except CatalogException as e:
         return [1, e.message]
     except:
         logger.error(traceback.format_exc())
         return [1, str(sys.exc_info())]
-    return [0,ret]
+    return [0, ret]
 
 
 class NsPackage(object):
index d287551..5089916 100644 (file)
@@ -115,7 +115,7 @@ def ns_model_parser(request, *args, **kwargs):
     csar_id = ignore_case_get(request.data, "csarId")
     inputs = ignore_case_get(request.data, "inputs")
     logger.debug("Enter %s, csar_id=%s, inputs=%s", fun_name(), csar_id, inputs)
-    ret = ns_package.parser_NSPackageModel(csar_id, inputs)
+    ret = ns_package.parse_nsd(csar_id, inputs)
     logger.info("Leave %s, Return value is %s", fun_name(), ret)
     if ret[0] != 0:
         return Response(data={'error': ret[1]}, status=status.HTTP_500_INTERNAL_SERVER_ERROR)
@@ -127,7 +127,7 @@ def vnf_model_parser(request, *args, **kwargs):
     csar_id = ignore_case_get(request.data, "csarId")
     inputs = ignore_case_get(request.data, "inputs")
     logger.debug("Enter %s, csar_id=%s, inputs=%s", fun_name(), csar_id, inputs)
-    nf_package.parser_vnfdmodel(csar_id, inputs)
+    nf_package.parse_vnfd(csar_id, inputs)
     logger.info("Leave %s, Return value is %s", fun_name(), ret)
     if ret[0] != 0:
         return Response(data={'error': ret[1]}, status=status.HTTP_500_INTERNAL_SERVER_ERROR)