+++ /dev/null
-# Copyright 2017 ZTE Corporation.
-#
-# Licensed under the Apache License, Version 2.0 (the "License");
-# you may not use this file except in compliance with the License.
-# You may obtain a copy of the License at
-#
-# http://www.apache.org/licenses/LICENSE-2.0
-#
-# Unless required by applicable law or agreed to in writing, software
-# distributed under the License is distributed on an "AS IS" BASIS,
-# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
-# See the License for the specific language governing permissions and
-# limitations under the License.
-
-import logging
-import uuid
-
-from drf_yasg import openapi
-from drf_yasg.utils import no_body, swagger_auto_schema
-from rest_framework import status
-from rest_framework.decorators import api_view
-from rest_framework.response import Response
-from genericparser.packages.biz import sdc_vnf_package, sdc_ns_package
-from genericparser.packages.biz.pnf_descriptor import PnfDescriptor
-from genericparser.packages.biz.sdc_service_package import ServicePackage
-from genericparser.packages.serializers.genericparser_serializers import InternalErrorRequestSerializer, \
- ServicePackageDistributeRequestSerializer, ServicePackagesSerializer, ServicePackageSerializer
-from genericparser.packages.serializers.genericparser_serializers import NfPackageDistributeRequestSerializer
-from genericparser.packages.serializers.genericparser_serializers import NfPackageSerializer
-from genericparser.packages.serializers.genericparser_serializers import NfPackagesSerializer
-from genericparser.packages.serializers.genericparser_serializers import NsPackageDistributeRequestSerializer
-from genericparser.packages.serializers.genericparser_serializers import NsPackageDistributeResponseSerializer
-from genericparser.packages.serializers.genericparser_serializers import NsPackageSerializer
-from genericparser.packages.serializers.genericparser_serializers import NsPackagesSerializer
-from genericparser.packages.serializers.genericparser_serializers import ParseModelRequestSerializer
-from genericparser.packages.serializers.genericparser_serializers import ParseModelResponseSerializer
-from genericparser.packages.serializers.genericparser_serializers import PostJobResponseSerializer
-from genericparser.packages.views.common import fmt_error_rsp
-from genericparser.pub.exceptions import PackageNotFoundException, PackageHasExistsException
-from genericparser.pub.utils.syscomm import fun_name
-from genericparser.pub.utils.values import ignore_case_get
-
-logger = logging.getLogger(__name__)
-
-
-@swagger_auto_schema(
- method='POST',
- operation_description="On distribute NS package",
- request_body=NsPackageDistributeRequestSerializer,
- responses={
- status.HTTP_202_ACCEPTED: NsPackageDistributeResponseSerializer,
- status.HTTP_500_INTERNAL_SERVER_ERROR: InternalErrorRequestSerializer})
-@swagger_auto_schema(
- method='GET',
- operation_description="Query NS packages",
- request_body=no_body,
- responses={
- status.HTTP_200_OK: NsPackagesSerializer,
- status.HTTP_500_INTERNAL_SERVER_ERROR: InternalErrorRequestSerializer})
-@api_view(http_method_names=['POST', 'GET'])
-def nspackages_rc(request, *args, **kwargs):
- logger.debug("Enter %s, method is %s", fun_name(), request.method)
- ret, normal_status, response_serializer, validation_error = None, None, None, None
-
- if request.method == 'GET':
- # Gets ns package list
- ret = sdc_ns_package.ns_get_csars()
- normal_status = status.HTTP_200_OK
-
- if ret[0] == 0:
- response_serializer = NsPackagesSerializer(data=ret[1])
- validation_error = handleValidatonError(
- response_serializer, False)
- if validation_error:
- return validation_error
- elif request.method == 'POST':
- # Distributes the package accroding to the given csarId
- request_serializer = NsPackageDistributeRequestSerializer(data=request.data)
- validation_error = handleValidatonError(request_serializer, True)
- if validation_error:
- return validation_error
-
- csar_id = ignore_case_get(request.data, "csarId")
- logger.debug("csar_id is %s", csar_id)
- ret = sdc_ns_package.ns_on_distribute(csar_id)
- normal_status = status.HTTP_202_ACCEPTED
-
- logger.debug("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)
-
- return Response(data=ret[1], status=normal_status)
-
-
-@swagger_auto_schema(
- method='POST',
- operation_description="On distribute Nf package",
- request_body=NfPackageDistributeRequestSerializer(),
- responses={
- status.HTTP_202_ACCEPTED: PostJobResponseSerializer,
- status.HTTP_500_INTERNAL_SERVER_ERROR: InternalErrorRequestSerializer})
-@swagger_auto_schema(
- method='GET',
- operation_description="Query Nf packages",
- request_body=no_body,
- responses={
- status.HTTP_200_OK: NfPackagesSerializer,
- status.HTTP_500_INTERNAL_SERVER_ERROR: InternalErrorRequestSerializer})
-@api_view(http_method_names=['POST', 'GET'])
-def nfpackages_rc(request, *args, **kwargs):
- logger.debug(
- "Enter %s%s, method is %s",
- fun_name(),
- request.data,
- request.method)
- ret, normal_status, response_serializer, validation_error = None, None, None, None
- if request.method == 'GET':
- ret = sdc_vnf_package.nf_get_csars()
- normal_status = status.HTTP_200_OK
- response_serializer = NfPackagesSerializer(data=ret[1])
- elif request.method == 'POST':
- request_serivalizer = NfPackageDistributeRequestSerializer(
- data=request.data)
- validation_error = handleValidatonError(
- request_serivalizer, True)
- if validation_error:
- return validation_error
-
- csar_id = ignore_case_get(request_serivalizer.data, "csarId")
- vim_ids = ignore_case_get(request_serivalizer.data, "vimIds")
- lab_vim_id = ignore_case_get(request_serivalizer.data, "labVimId")
- job_id = str(uuid.uuid4())
- sdc_vnf_package.NfDistributeThread(
- csar_id, vim_ids, lab_vim_id, job_id).start()
- ret = [0, {"jobId": job_id}]
- normal_status = status.HTTP_202_ACCEPTED
-
- response_serializer = PostJobResponseSerializer(data=ret[1])
- logger.debug("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)
-
- validation_error = handleValidatonError(
- response_serializer, False)
- if validation_error:
- return validation_error
-
- return Response(data=response_serializer.data, status=normal_status)
-
-
-@swagger_auto_schema(
- method='DELETE',
- operation_description="Delete one NS package",
- request_body=no_body,
- manual_parameters=[
- openapi.Parameter(
- 'csarId',
- openapi.IN_QUERY,
- "csarId",
- type=openapi.TYPE_STRING)],
- responses={
- status.HTTP_200_OK: NsPackageDistributeResponseSerializer,
- status.HTTP_500_INTERNAL_SERVER_ERROR: openapi.Response(
- 'error message',
- openapi.Schema(
- type=openapi.TYPE_STRING))})
-@swagger_auto_schema(
- method='GET',
- operation_description="Query one NS package",
- request_body=no_body,
- manual_parameters=[
- openapi.Parameter(
- 'csarId',
- openapi.IN_QUERY,
- "csarId",
- type=openapi.TYPE_STRING)],
- responses={
- status.HTTP_200_OK: NsPackageSerializer,
- status.HTTP_500_INTERNAL_SERVER_ERROR: openapi.Response(
- 'error message',
- openapi.Schema(
- type=openapi.TYPE_STRING))})
-@api_view(http_method_names=['DELETE', 'GET'])
-def ns_rd_csar(request, *args, **kwargs):
- csar_id = ignore_case_get(kwargs, "csarId")
- logger.info("Enter %s, method is %s, csar_id is %s",
- fun_name(), request.method, csar_id)
- ret, normal_status, response_serializer, validation_error = None, None, None, None
- if request.method == 'GET':
- ret = sdc_ns_package.ns_get_csar(csar_id)
- normal_status = status.HTTP_200_OK
- if ret[0] == 0:
- response_serializer = NsPackageSerializer(data=ret[1])
- validation_error = handleValidatonError(response_serializer, False)
- if validation_error:
- return validation_error
- elif request.method == 'DELETE':
- ret = sdc_ns_package.ns_delete_csar(csar_id)
- normal_status = status.HTTP_200_OK
- 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)
- return Response(data=ret[1], status=normal_status)
-
-
-@swagger_auto_schema(
- method='POST',
- operation_description="On distribute Service package",
- request_body=ServicePackageDistributeRequestSerializer,
- responses={
- status.HTTP_202_ACCEPTED: "",
- status.HTTP_400_BAD_REQUEST: InternalErrorRequestSerializer,
- status.HTTP_500_INTERNAL_SERVER_ERROR: InternalErrorRequestSerializer})
-@swagger_auto_schema(
- method='GET',
- operation_description="Query Service packages",
- request_body=no_body,
- responses={
- status.HTTP_200_OK: ServicePackagesSerializer,
- status.HTTP_500_INTERNAL_SERVER_ERROR: InternalErrorRequestSerializer})
-@api_view(http_method_names=['POST', 'GET'])
-def servicepackages_rc(request, *args, **kwargs):
- logger.debug("Enter %s, method is %s", fun_name(), request.method)
-
- if request.method == 'GET':
- # Gets service package list
- try:
- csar_list = ServicePackage().get_csars()
- response_serializer = ServicePackagesSerializer(data=csar_list)
- validation_error = handleValidatonError(response_serializer, False)
- if validation_error:
- return validation_error
- return Response(data=csar_list, status=status.HTTP_200_OK)
- except Exception as e:
- error_status = status.HTTP_500_INTERNAL_SERVER_ERROR
- return Response(data=fmt_error_rsp(e.args[0], error_status), status=error_status)
- elif request.method == 'POST':
- # Distributes the package according to the given csarId
- request_serializer = ServicePackageDistributeRequestSerializer(data=request.data)
- validation_error = handleValidatonError(request_serializer, True)
- if validation_error:
- return validation_error
-
- csar_id = ignore_case_get(request.data, "csarId")
- logger.debug("csar_id is %s", csar_id)
- try:
- ServicePackage().on_distribute(csar_id)
- return Response(status=status.HTTP_202_ACCEPTED)
- except PackageHasExistsException as e:
- error_status = status.HTTP_400_BAD_REQUEST
- return Response(data=fmt_error_rsp(e.args[0], error_status), status=error_status)
- except Exception as e:
- error_status = status.HTTP_500_INTERNAL_SERVER_ERROR
- return Response(data=fmt_error_rsp(e.args[0], error_status), status=error_status)
-
-
-@swagger_auto_schema(
- method='DELETE',
- operation_description="Delete one Service package",
- request_body=no_body,
- manual_parameters=[
- openapi.Parameter(
- 'csarId',
- openapi.IN_QUERY,
- "csarId",
- type=openapi.TYPE_STRING)],
- responses={
- status.HTTP_204_NO_CONTENT: "",
- status.HTTP_404_NOT_FOUND: InternalErrorRequestSerializer,
- status.HTTP_500_INTERNAL_SERVER_ERROR: InternalErrorRequestSerializer})
-@swagger_auto_schema(
- method='GET',
- operation_description="Query one Service package",
- request_body=no_body,
- manual_parameters=[
- openapi.Parameter(
- 'csarId',
- openapi.IN_QUERY,
- "csarId",
- type=openapi.TYPE_STRING)],
- responses={
- status.HTTP_200_OK: ServicePackageSerializer,
- status.HTTP_404_NOT_FOUND: InternalErrorRequestSerializer,
- status.HTTP_500_INTERNAL_SERVER_ERROR: InternalErrorRequestSerializer})
-@api_view(http_method_names=['DELETE', 'GET'])
-def service_rd_csar(request, *args, **kwargs):
- csar_id = ignore_case_get(kwargs, "csarId")
- logger.info("Enter %s, method is %s, csar_id is %s", fun_name(), request.method, csar_id)
-
- if request.method == 'GET':
- try:
- ret = ServicePackage().get_csar(csar_id)
- response_serializer = ServicePackageSerializer(data=ret)
- validation_error = handleValidatonError(response_serializer, False)
- if validation_error:
- return validation_error
- return Response(data=ret, status=status.HTTP_200_OK)
- except PackageNotFoundException as e:
- error_status = status.HTTP_404_NOT_FOUND
- return Response(data=fmt_error_rsp(e.args[0], error_status), status=error_status)
- except Exception as e:
- error_status = status.HTTP_500_INTERNAL_SERVER_ERROR
- return Response(data=fmt_error_rsp(e.args[0], error_status), status=error_status)
-
- elif request.method == 'DELETE':
- try:
- ServicePackage().delete_csar(csar_id)
- return Response(status=status.HTTP_204_NO_CONTENT)
- except PackageNotFoundException as e:
- error_status = status.HTTP_404_NOT_FOUND
- return Response(data=fmt_error_rsp(e.args[0], error_status), status=error_status)
- except Exception as e:
- error_status = status.HTTP_500_INTERNAL_SERVER_ERROR
- return Response(data=fmt_error_rsp(e.args[0], error_status), status=error_status)
-
-
-@swagger_auto_schema(
- method='DELETE',
- operation_description="Delete one Nf package",
- request_body=no_body,
- manual_parameters=[
- openapi.Parameter(
- 'csarId',
- openapi.IN_QUERY,
- "csarId",
- type=openapi.TYPE_STRING)],
- responses={
- status.HTTP_202_ACCEPTED: PostJobResponseSerializer,
- status.HTTP_500_INTERNAL_SERVER_ERROR: openapi.Response(
- 'error message',
- openapi.Schema(
- type=openapi.TYPE_STRING))})
-@swagger_auto_schema(
- method='GET',
- operation_description="Query one Nf package",
- request_body=no_body,
- manual_parameters=[
- openapi.Parameter(
- 'csarId',
- openapi.IN_QUERY,
- "csarId",
- type=openapi.TYPE_STRING)],
- responses={
- status.HTTP_200_OK: NfPackageSerializer,
- status.HTTP_500_INTERNAL_SERVER_ERROR: openapi.Response(
- 'error message',
- openapi.Schema(
- type=openapi.TYPE_STRING))})
-@api_view(http_method_names=['DELETE', 'GET'])
-def nf_rd_csar(request, *args, **kwargs):
- csar_id = ignore_case_get(kwargs, "csarId")
- logger.info("Enter %s, method is %s, csar_id is %s",
- fun_name(), request.method, csar_id)
- ret, normal_status, response_serializer, validation_error = None, None, None, None
-
- if request.method == 'GET':
- ret = sdc_vnf_package.nf_get_csar(csar_id)
- normal_status = status.HTTP_200_OK
- response_serializer = NfPackageSerializer(data=ret[1])
-
- elif request.method == 'DELETE':
- job_id = str(uuid.uuid4())
- sdc_vnf_package.NfPkgDeleteThread(csar_id, job_id).start()
- ret = [0, {"jobId": job_id}]
- normal_status = status.HTTP_202_ACCEPTED
- response_serializer = PostJobResponseSerializer(data=ret[1])
-
- 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)
-
- validation_error = handleValidatonError(
- response_serializer, False)
- if validation_error:
- return validation_error
-
- return Response(data=response_serializer.data, status=normal_status)
-
-
-@swagger_auto_schema(
- method='POST',
- operation_description="Parse model(NS, Service, VNF, PNF)",
- request_body=ParseModelRequestSerializer,
- responses={
- status.HTTP_202_ACCEPTED: ParseModelResponseSerializer,
- status.HTTP_500_INTERNAL_SERVER_ERROR: InternalErrorRequestSerializer})
-@api_view(http_method_names=['POST'])
-def model_parser(request, *args, **kwargs):
- csar_id = ignore_case_get(request.data, "csarId")
- package_type = ignore_case_get(request.data, "packageType")
- inputs = ignore_case_get(request.data, "inputs")
- logger.debug(
- "Enter %s, csar_id=%s, package_type=%s, inputs=%s",
- fun_name(),
- csar_id,
- package_type,
- inputs)
-
- if package_type.lower().__eq__("service"):
- try:
- ret = ServicePackage().parse_serviced(csar_id, inputs)
- response_serializer = ParseModelResponseSerializer(data=ret)
- validation_error = handleValidatonError(
- response_serializer, False)
- if validation_error:
- return validation_error
- return Response(data=response_serializer.data, status=status.HTTP_202_ACCEPTED)
- except PackageNotFoundException as e:
- error_status = status.HTTP_404_NOT_FOUND
- return Response(data=fmt_error_rsp(e.args[0], error_status), status=error_status)
- except Exception as e:
- error_status = status.HTTP_500_INTERNAL_SERVER_ERROR
- return Response(data=fmt_error_rsp(e.args[0], error_status), status=error_status)
- elif package_type.lower().__eq__("ns"):
- ret = sdc_ns_package.parse_nsd(csar_id, inputs)
- elif package_type.lower().__eq__("vnf"):
- ret = sdc_vnf_package.parse_vnfd(csar_id, inputs)
- elif package_type.lower().__eq__("pnf"):
- ret = PnfDescriptor().parse_pnfd(csar_id, inputs)
- else:
- error_status = status.HTTP_400_BAD_REQUEST
- error_message = "Invalid package type, it should be one of [VNF, PNF, NS, Service]"
- return Response(data=fmt_error_rsp(error_message, error_status), status=error_status)
-
- if ret[0] != 0:
- return Response(
- data={
- 'error': ret[1]},
- status=status.HTTP_500_INTERNAL_SERVER_ERROR)
-
- response_serializer = ParseModelResponseSerializer(data=ret[1])
- validation_error = handleValidatonError(
- response_serializer, False)
- if validation_error:
- return validation_error
-
- return Response(data=response_serializer.data, status=status.HTTP_202_ACCEPTED)
-
-
-@swagger_auto_schema(
- method='POST',
- operation_description="Parse NS model",
- request_body=ParseModelRequestSerializer,
- responses={
- status.HTTP_202_ACCEPTED: ParseModelResponseSerializer,
- status.HTTP_500_INTERNAL_SERVER_ERROR: InternalErrorRequestSerializer})
-@api_view(http_method_names=['POST'])
-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 = sdc_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)
-
- response_serializer = ParseModelResponseSerializer(data=ret[1])
- validation_error = handleValidatonError(
- response_serializer, False)
- if validation_error:
- return validation_error
-
- return Response(data=response_serializer.data, status=status.HTTP_202_ACCEPTED)
-
-
-@swagger_auto_schema(
- method='POST',
- operation_description="Parse NF model",
- request_body=ParseModelRequestSerializer,
- responses={
- status.HTTP_202_ACCEPTED: ParseModelResponseSerializer,
- status.HTTP_500_INTERNAL_SERVER_ERROR: InternalErrorRequestSerializer})
-@api_view(http_method_names=['POST'])
-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)
- ret = sdc_vnf_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)
-
- response_serializer = ParseModelResponseSerializer(data=ret[1])
- validation_error = handleValidatonError(
- response_serializer, False)
- if validation_error:
- return validation_error
-
- return Response(data=response_serializer.data, status=status.HTTP_202_ACCEPTED)
-
-
-def handleValidatonError(base_serializer, is_request):
- response = None
-
- if not base_serializer.is_valid():
- errormessage = base_serializer.errors
- logger.error(errormessage)
-
- if is_request:
- message = 'Invalid request'
- else:
- message = 'Invalid response'
- logger.error(message)
- response = Response(
- data={'error': errormessage},
- status=status.HTTP_500_INTERNAL_SERVER_ERROR)
-
- return response
Code Review / modeling / etsicatalog.git / blobdiff