diff options
author | fujinhua <fu.jinhua@zte.com.cn> | 2019-04-09 15:50:38 +0800 |
---|---|---|
committer | fujinhua <fu.jinhua@zte.com.cn> | 2019-04-09 15:59:43 +0800 |
commit | f5a0353d4127f32ebc95012b24f344b858ceec3a (patch) | |
tree | 6505c33a18c0eac054cb55bc33570b72f1a22a7e | |
parent | 24cfbe81740cb83f75e84e96f7f8db50ba949410 (diff) |
Refactor codes for vnf pkg
Change-Id: I7d35010cd4ee58ce57583b2c0183b68143b0b06c
Issue-ID: VFC-1306
Signed-off-by: fujinhua <fu.jinhua@zte.com.cn>
-rw-r--r-- | catalog/packages/views/vnf_package_views.py | 98 |
1 files changed, 25 insertions, 73 deletions
diff --git a/catalog/packages/views/vnf_package_views.py b/catalog/packages/views/vnf_package_views.py index da88dfd7..b3d84dbe 100644 --- a/catalog/packages/views/vnf_package_views.py +++ b/catalog/packages/views/vnf_package_views.py @@ -12,7 +12,6 @@ # See the License for the specific language governing permissions and # limitations under the License. -import traceback import logging from django.http import StreamingHttpResponse @@ -20,13 +19,14 @@ from drf_yasg.utils import swagger_auto_schema, no_body from rest_framework import status from rest_framework.decorators import api_view from rest_framework.response import Response -from catalog.pub.exceptions import CatalogException, ResourceNotFoundException +from catalog.pub.exceptions import CatalogException from catalog.packages.serializers.upload_vnf_pkg_from_uri_req import UploadVnfPackageFromUriRequestSerializer from catalog.packages.serializers.create_vnf_pkg_info_req import CreateVnfPkgInfoRequestSerializer from catalog.packages.serializers.vnf_pkg_info import VnfPkgInfoSerializer from catalog.packages.serializers.vnf_pkg_infos import VnfPkgInfosSerializer from catalog.packages.biz.vnf_package import VnfPackage, VnfPkgUploadThread, parse_vnfd_and_save, handle_upload_failed from catalog.packages.views.common import validate_data +from .common import view_safe_call_with_log logger = logging.getLogger(__name__) @@ -50,31 +50,20 @@ logger = logging.getLogger(__name__) } ) @api_view(http_method_names=["GET", "POST"]) +@view_safe_call_with_log(logger=logger) def vnf_packages_rc(request): if request.method == 'GET': logger.debug("Query VNF packages> %s" % request.data) - try: - data = VnfPackage().query_multiple() - vnf_pkg_infos = validate_data(data, VnfPkgInfosSerializer) - return Response(data=vnf_pkg_infos.data, status=status.HTTP_200_OK) - except Exception as e: - logger.error(e.message) - logger.error(traceback.format_exc()) - error_data = {'error': 'Query of multiple VNF packages failed'} - return Response(data=error_data, status=status.HTTP_500_INTERNAL_SERVER_ERROR) + data = VnfPackage().query_multiple() + vnf_pkg_infos = validate_data(data, VnfPkgInfosSerializer) + return Response(data=vnf_pkg_infos.data, status=status.HTTP_200_OK) if request.method == 'POST': logger.debug("Create VNF package> %s" % request.data) - try: - create_vnf_pkg_info_request = validate_data(request.data, CreateVnfPkgInfoRequestSerializer) - data = VnfPackage().create_vnf_pkg(create_vnf_pkg_info_request.data) - vnf_pkg_info = validate_data(data, VnfPkgInfoSerializer) - return Response(data=vnf_pkg_info.data, status=status.HTTP_201_CREATED) - except Exception as e: - logger.error(e.message) - logger.error(traceback.format_exc()) - error_data = {'error': 'Creating a VNF Package failed'} - return Response(data=error_data, status=status.HTTP_500_INTERNAL_SERVER_ERROR) + create_vnf_pkg_info_request = validate_data(request.data, CreateVnfPkgInfoRequestSerializer) + data = VnfPackage().create_vnf_pkg(create_vnf_pkg_info_request.data) + vnf_pkg_info = validate_data(data, VnfPkgInfoSerializer) + return Response(data=vnf_pkg_info.data, status=status.HTTP_201_CREATED) @swagger_auto_schema( @@ -97,6 +86,7 @@ def vnf_packages_rc(request): } ) @api_view(http_method_names=["PUT", "GET"]) +@view_safe_call_with_log(logger=logger) def package_content_ru(request, **kwargs): vnf_pkg_id = kwargs.get("vnfPkgId") if request.method == "PUT": @@ -108,34 +98,15 @@ def package_content_ru(request, **kwargs): return Response(None, status=status.HTTP_202_ACCEPTED) except CatalogException as e: handle_upload_failed(vnf_pkg_id) - logger.error(e.message) - error_data = {'error': e.message} + raise e except Exception as e: handle_upload_failed(vnf_pkg_id) - logger.error(e.message) - logger.error(traceback.format_exc()) - error_data = {'error': 'Uploading VNF package(%s) failed.' % vnf_pkg_id} - return Response(data=error_data, status=status.HTTP_500_INTERNAL_SERVER_ERROR) + raise e if request.method == "GET": - try: - file_range = request.META.get('RANGE') - file_iterator = VnfPackage().download(vnf_pkg_id, file_range) - return StreamingHttpResponse(file_iterator, status=status.HTTP_200_OK) - except ResourceNotFoundException as e: - logger.error(e.message) - error_data = {'error': e.message} - error_code = status.HTTP_404_NOT_FOUND - except CatalogException as e: - logger.error(e.message) - error_data = {'error': e.message} - error_code = status.HTTP_500_INTERNAL_SERVER_ERROR - except Exception as e: - logger.error(e.message) - logger.error(traceback.format_exc()) - error_data = {'error': 'Downloading VNF package(%s) failed.' % vnf_pkg_id} - error_code = status.HTTP_500_INTERNAL_SERVER_ERROR - return Response(data=error_data, status=error_code) + file_range = request.META.get('RANGE') + file_iterator = VnfPackage().download(vnf_pkg_id, file_range) + return StreamingHttpResponse(file_iterator, status=status.HTTP_200_OK) @swagger_auto_schema( @@ -148,6 +119,7 @@ def package_content_ru(request, **kwargs): } ) @api_view(http_method_names=['POST']) +@view_safe_call_with_log(logger=logger) def upload_from_uri_c(request, **kwargs): vnf_pkg_id = kwargs.get("vnfPkgId") try: @@ -156,14 +128,10 @@ def upload_from_uri_c(request, **kwargs): return Response(None, status=status.HTTP_202_ACCEPTED) except CatalogException as e: handle_upload_failed(vnf_pkg_id) - logger.error(e.message) - error_data = {'error': e.message} + raise e except Exception as e: handle_upload_failed(vnf_pkg_id) - logger.error(e.message) - logger.error(traceback.format_exc()) - error_data = {'error': 'Uploading VNF package(%s) from URI failed.' % vnf_pkg_id} - return Response(data=error_data, status=status.HTTP_500_INTERNAL_SERVER_ERROR) + raise e @swagger_auto_schema( @@ -186,32 +154,16 @@ def upload_from_uri_c(request, **kwargs): } ) @api_view(http_method_names=['GET', 'DELETE']) +@view_safe_call_with_log(logger=logger) def vnf_package_rd(request, **kwargs): vnf_pkg_id = kwargs.get("vnfPkgId") if request.method == 'GET': logger.debug("Query an individual VNF package> %s" % request.data) - try: - data = VnfPackage().query_single(vnf_pkg_id) - vnf_pkg_info = validate_data(data, VnfPkgInfoSerializer) - return Response(data=vnf_pkg_info.data, status=status.HTTP_200_OK) - except ResourceNotFoundException as e: - logger.error(e.message) - error_data = {'error': e.message} - error_code = status.HTTP_404_NOT_FOUND - except Exception as e: - logger.error(e.message) - logger.error(traceback.format_exc()) - error_data = {'error': 'Query of VNF package(%s) failed.' % vnf_pkg_id} - error_code = status.HTTP_500_INTERNAL_SERVER_ERROR - return Response(data=error_data, status=error_code) + data = VnfPackage().query_single(vnf_pkg_id) + vnf_pkg_info = validate_data(data, VnfPkgInfoSerializer) + return Response(data=vnf_pkg_info.data, status=status.HTTP_200_OK) if request.method == 'DELETE': logger.debug("Delete an individual VNF package> %s" % request.data) - try: - VnfPackage().delete_vnf_pkg(vnf_pkg_id) - return Response(data=None, status=status.HTTP_204_NO_CONTENT) - except Exception as e: - logger.error(e.message) - logger.error(traceback.format_exc()) - error_data = {'error': 'Deletion of VNF package(%s) failed.' % vnf_pkg_id} - return Response(data=error_data, status=status.HTTP_500_INTERNAL_SERVER_ERROR) + VnfPackage().delete_vnf_pkg(vnf_pkg_id) + return Response(data=None, status=status.HTTP_204_NO_CONTENT) |