lcm/lcm/nf/vnfs/views.py

   1 # Copyright 2017 ZTE Corporation.
   2 #
   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
   6 #
   7 #         http://www.apache.org/licenses/LICENSE-2.0
   8 #
   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.
  14
  15 import logging
  16 import traceback
  17
  18 from drf_yasg.utils import swagger_auto_schema
  19 from rest_framework import status
  20 from rest_framework.response import Response
  21 from rest_framework.views import APIView
  22
  23 from lcm.nf.vnfs.serializers import CreateVnfReqSerializer, CreateVnfRespSerializer, VnfsInfoSerializer, \
  24     InstOrTeriVnfResponseSerializer, InstantiateVnfRequestSerializer, VnfInfoSerializer, TerminateVnfRequestSerializer
  25 from lcm.nf.vnfs.vnf_cancel.delete_vnf_identifier import DeleteVnf
  26 from lcm.nf.vnfs.vnf_cancel.term_vnf import TermVnf
  27 from lcm.nf.vnfs.vnf_create.create_vnf_identifier import CreateVnf
  28 from lcm.nf.vnfs.vnf_create.inst_vnf import InstVnf
  29 from lcm.nf.vnfs.vnf_query.query_vnf import QueryVnf
  30 from lcm.pub.exceptions import NFLCMException
  31 from lcm.pub.utils.jobutil import JobUtil
  32
  33 logger = logging.getLogger(__name__)
  34
  35
  36 class CreateVnfAndQueryVnfs(APIView):
  37     @swagger_auto_schema(
  38         responses={
  39             status.HTTP_200_OK: VnfsInfoSerializer(),
  40             status.HTTP_500_INTERNAL_SERVER_ERROR: "Internal error"
  41         }
  42     )
  43     def get(self, request):
  44         logger.debug("QueryMultiVnf--get::> %s" % request.data)
  45         try:
  46             resp_data = QueryVnf(request.data).query_multi_vnf()
  47
  48             vnfs_info_serializer = VnfsInfoSerializer(data=resp_data)
  49             resp_isvalid = vnfs_info_serializer.is_valid()
  50             if not resp_isvalid:
  51                 raise NFLCMException(vnfs_info_serializer.errors)
  52
  53             return Response(data=vnfs_info_serializer.data, status=status.HTTP_200_OK)
  54         except NFLCMException as e:
  55             logger.error(e.message)
  56             return Response(data={'error': '%s' % e.message}, status=status.HTTP_500_INTERNAL_SERVER_ERROR)
  57         except Exception as e:
  58             logger.error(e.message)
  59             logger.error(traceback.format_exc())
  60             return Response(data={'error': 'Failed to get Vnfs'}, status=status.HTTP_500_INTERNAL_SERVER_ERROR)
  61
  62     @swagger_auto_schema(
  63         request_body=CreateVnfReqSerializer(),
  64         responses={
  65             status.HTTP_201_CREATED: CreateVnfRespSerializer(),
  66             status.HTTP_500_INTERNAL_SERVER_ERROR: "Internal error"
  67         }
  68     )
  69     def post(self, request):
  70         logger.debug("CreateVnfIdentifier--post::> %s" % request.data)
  71         req_serializer = CreateVnfReqSerializer(data=request.data)
  72         req_isvalid = req_serializer.is_valid()
  73         try:
  74             if not req_isvalid:
  75                 raise NFLCMException(req_serializer.errors)
  76
  77             nf_inst_id = CreateVnf(req_serializer.data).do_biz()
  78
  79             create_vnf_resp_serializer = CreateVnfRespSerializer(data={"vnfInstanceId": nf_inst_id})
  80             resp_isvalid = create_vnf_resp_serializer.is_valid()
  81             if not resp_isvalid:
  82                 raise NFLCMException(create_vnf_resp_serializer.errors)
  83             return Response(data=create_vnf_resp_serializer.data, status=status.HTTP_201_CREATED)
  84         except NFLCMException as e:
  85             logger.error(e.message)
  86             return Response(data={'error': '%s' % e.message}, status=status.HTTP_500_INTERNAL_SERVER_ERROR)
  87         except Exception as e:
  88             logger.error(e.message)
  89             logger.error(traceback.format_exc())
  90             return Response(data={'error': 'unexpected exception'}, status=status.HTTP_500_INTERNAL_SERVER_ERROR)
  91
  92
  93 class InstantiateVnf(APIView):
  94     @swagger_auto_schema(
  95         request_body=InstantiateVnfRequestSerializer(),
  96         responses={
  97             status.HTTP_202_ACCEPTED: InstOrTeriVnfResponseSerializer(),
  98             status.HTTP_500_INTERNAL_SERVER_ERROR: "Internal error"
  99         }
 100     )
 101     def post(self, request, instanceid):
 102         logger.debug("InstantiateVnf--post::> %s" % request.data)
 103         instantiate_vnf_request_serializer = InstantiateVnfRequestSerializer(data=request.data)
 104         req_isvalid = instantiate_vnf_request_serializer.is_valid()
 105         try:
 106             if not req_isvalid:
 107                 raise NFLCMException(instantiate_vnf_request_serializer.errors)
 108
 109             job_id = JobUtil.create_job('NF', 'INSTANTIATE', instanceid)
 110             JobUtil.add_job_status(job_id, 0, "INST_VNF_READY")
 111             InstVnf(instantiate_vnf_request_serializer.data, instanceid, job_id).start()
 112
 113             instantiate_vnf_response_serializer = InstOrTeriVnfResponseSerializer(data={"jobId": job_id})
 114             resp_isvalid = instantiate_vnf_response_serializer.is_valid()
 115             if not resp_isvalid:
 116                 raise NFLCMException(instantiate_vnf_response_serializer.errors)
 117
 118             return Response(data=instantiate_vnf_response_serializer.data, status=status.HTTP_202_ACCEPTED)
 119         except NFLCMException as e:
 120             logger.error(e.message)
 121             return Response(data={'error': '%s' % e.message}, status=status.HTTP_500_INTERNAL_SERVER_ERROR)
 122         except Exception as e:
 123             logger.error(e.message)
 124             logger.error(traceback.format_exc())
 125             return Response(data={'error': 'unexpected exception'}, status=status.HTTP_500_INTERNAL_SERVER_ERROR)
 126
 127
 128 class DeleteVnfAndQueryVnf(APIView):
 129     @swagger_auto_schema(
 130         responses={
 131             status.HTTP_200_OK: VnfInfoSerializer(),
 132             status.HTTP_500_INTERNAL_SERVER_ERROR: "Internal error"
 133         }
 134     )
 135     def get(self, request, instanceid):
 136         logger.debug("QuerySingleVnf--get::> %s" % request.data)
 137         try:
 138             resp_data = QueryVnf(request.data, instanceid).query_single_vnf()
 139
 140             vnf_info_serializer = VnfInfoSerializer(data=resp_data)
 141             resp_isvalid = vnf_info_serializer.is_valid()
 142             if not resp_isvalid:
 143                 raise NFLCMException(vnf_info_serializer.errors)
 144
 145             return Response(data=vnf_info_serializer.data, status=status.HTTP_200_OK)
 146         except NFLCMException as e:
 147             logger.error(e.message)
 148             return Response(data={'error': '%s' % e.message}, status=status.HTTP_500_INTERNAL_SERVER_ERROR)
 149         except Exception as e:
 150             logger.eror(e.message)
 151             logger.error(traceback.format_exc())
 152             return Response(data={'error': 'Failed to get Vnf(%s)' % instanceid},
 153                             status=status.HTTP_500_INTERNAL_SERVER_ERROR)
 154
 155     @swagger_auto_schema(
 156         responses={
 157             status.HTTP_204_NO_CONTENT: "Successfully",
 158             status.HTTP_500_INTERNAL_SERVER_ERROR: "Internal error"
 159         }
 160     )
 161     def delete(self, request, instanceid):
 162         logger.debug("DeleteVnfIdentifier--delete::> %s" % request.data)
 163         try:
 164             DeleteVnf(request.data, instanceid).do_biz()
 165
 166             return Response(data=None, status=status.HTTP_204_NO_CONTENT)
 167         except NFLCMException as e:
 168             logger.error(e.message)
 169             return Response(data={'error': '%s' % e.message}, status=status.HTTP_500_INTERNAL_SERVER_ERROR)
 170         except Exception as e:
 171             logger.error(e.message)
 172             logger.error(traceback.format_exc())
 173             return Response(data={'error': 'unexpected exception'}, status=status.HTTP_500_INTERNAL_SERVER_ERROR)
 174
 175
 176 class TerminateVnf(APIView):
 177     @swagger_auto_schema(
 178         request_body=TerminateVnfRequestSerializer(),
 179         responses={
 180             status.HTTP_202_ACCEPTED: InstOrTeriVnfResponseSerializer(),
 181             status.HTTP_500_INTERNAL_SERVER_ERROR: "Internal error"
 182         }
 183     )
 184     def post(self, request, instanceid):
 185         logger.debug("TerminateVnf--post::> %s" % request.data)
 186         try:
 187             job_id = JobUtil.create_job('NF', 'TERMINATE', instanceid)
 188             JobUtil.add_job_status(job_id, 0, "TERM_VNF_READY")
 189             TermVnf(request.data, instanceid, job_id).start()
 190
 191             terminate_vnf_response_serializer = InstOrTeriVnfResponseSerializer(data={"jobId": job_id})
 192             resp_isvalid = terminate_vnf_response_serializer.is_valid()
 193             if not resp_isvalid:
 194                 raise NFLCMException(terminate_vnf_response_serializer.errors)
 195
 196             return Response(data=terminate_vnf_response_serializer.data, status=status.HTTP_202_ACCEPTED)
 197         except NFLCMException as e:
 198             logger.error(e.message)
 199             return Response(data={'error': '%s' % e.message}, status=status.HTTP_500_INTERNAL_SERVER_ERROR)
 200         except Exception as e:
 201             logger.error(e.message)
 202             logger.error(traceback.format_exc())
 203             return Response(data={'error': 'unexpected exception'}, status=status.HTTP_500_INTERNAL_SERVER_ERROR)