diff options
| -rw-r--r-- | lcm/lcm/nf/serializers/change_ext_vnf_connectivity_request.py | 43 | ||||
| -rw-r--r-- | lcm/lcm/nf/views/change_ext_conn_view.py | 73 |
2 files changed, 116 insertions, 0 deletions
diff --git a/lcm/lcm/nf/serializers/change_ext_vnf_connectivity_request.py b/lcm/lcm/nf/serializers/change_ext_vnf_connectivity_request.py new file mode 100644 index 00000000..2eb167ad --- /dev/null +++ b/lcm/lcm/nf/serializers/change_ext_vnf_connectivity_request.py @@ -0,0 +1,43 @@ +# Copyright (C) 2019 ZTE. All Rights Reserved. +# +# 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. + +from rest_framework import serializers +from .ext_virtual_link_data import ExtVirtualLinkDataSerizlizer +from .vim_connection_info import VimConnectionInfoSerializer + + +class ChangeExtVnfConnectivityRequestSerializer(serializers.Serializer): + extVirtualLinks = ExtVirtualLinkDataSerizlizer( + help_text="Information about external VLs to change (e.g. connect the VNF to).", + many=True, + required=True, + allow_null=False + ) + vimConnectionInfo = VimConnectionInfoSerializer( + help_text="Information about VIM connections to be used for " + + "managing the resources for the VNF instance, " + + "or refer to external virtual links." + + "This attribute shall only be supported and may be present " + + "if VNF-related resource management in direct mode is applicable.", + many=True, + required=False, + allow_null=True + ) + additionalParams = serializers.DictField( + help_text="Additional parameters passed by the NFVO as input to the process, " + + "specific to the VNF of which the external connectivity is changed, " + + "as declared in the VNFD as part of 'ChangeExtVnfConnectivityOpConfig'.", + required=False, + allow_null=True + ) diff --git a/lcm/lcm/nf/views/change_ext_conn_view.py b/lcm/lcm/nf/views/change_ext_conn_view.py new file mode 100644 index 00000000..bfe0bfa5 --- /dev/null +++ b/lcm/lcm/nf/views/change_ext_conn_view.py @@ -0,0 +1,73 @@ +# Copyright (C) 2019 ZTE. All Rights Reserved. +# +# 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 + +from drf_yasg.utils import swagger_auto_schema +from rest_framework import status +from rest_framework.response import Response +from rest_framework.views import APIView + +from lcm.nf.serializers.change_ext_vnf_connectivity_request import ChangeExtVnfConnectivityRequestSerializer +from lcm.nf.serializers.response import ProblemDetailsSerializer +from lcm.pub.exceptions import NFLCMException +from lcm.pub.exceptions import NFLCMExceptionNotFound +from lcm.pub.exceptions import NFLCMExceptionConflict +from lcm.pub.utils.jobutil import JobUtil +from lcm.pub.database.models import NfInstModel +from lcm.nf.const import VNF_STATUS +from .common import view_safe_call_with_log + +logger = logging.getLogger(__name__) + + +class ChangeExtConnView(APIView): + @swagger_auto_schema( + request_body=ChangeExtVnfConnectivityRequestSerializer(), + responses={ + status.HTTP_202_ACCEPTED: "Success", + status.HTTP_404_NOT_FOUND: ProblemDetailsSerializer(), + status.HTTP_409_CONFLICT: ProblemDetailsSerializer(), + status.HTTP_500_INTERNAL_SERVER_ERROR: "Internal error" + } + ) + @view_safe_call_with_log(logger=logger) + def post(self, request, instanceid): + logger.debug("ChangeExtConn--post::> %s" % request.data) + + chg_ext_conn_serializer = ChangeExtVnfConnectivityRequestSerializer(data=request.data) + if not chg_ext_conn_serializer.is_valid(): + raise NFLCMException(chg_ext_conn_serializer.errors) + + job_id = JobUtil.create_job('NF', 'CHG_EXT_CONN', instanceid) + JobUtil.add_job_status(job_id, 0, "CHG_EXT_CONN_READY") + self.chg_ext_conn_pre_check(instanceid, job_id) + + # TODO: call biz logic + + response = Response(data={"jobId": job_id}, + status=status.HTTP_202_ACCEPTED) + return response + + def chg_ext_conn_pre_check(self, nf_inst_id, job_id): + vnf_insts = NfInstModel.objects.filter(nfinstid=nf_inst_id) + if not vnf_insts.exists(): + raise NFLCMExceptionNotFound("VNF nf_inst_id does not exist.") + + if vnf_insts[0].status != 'INSTANTIATED': + raise NFLCMExceptionConflict("VNF instantiationState is not INSTANTIATED.") + + vnf_insts.update(status=VNF_STATUS.UPDATING) + JobUtil.add_job_status(job_id, 15, 'Nf change ext conn pre-check finish') + logger.info("Nf change ext conn pre-check finish") |