1 # Copyright 2016 ZTE Corporation.
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
7 # http://www.apache.org/licenses/LICENSE-2.0
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.
19 from rest_framework import status
20 from rest_framework.response import Response
22 from lcm.ns_vnfs.enum import INST_TYPE
23 from lcm.pub.config.config import REPORT_TO_AAI
24 from lcm.pub.database.models import (CPInstModel, NfInstModel, PortInstModel,
25 VLInstModel, VmInstModel, VNFCInstModel)
26 from lcm.pub.exceptions import NSLCMException
27 from lcm.pub.msapi.aai import (create_network_aai, create_vserver_aai,
28 delete_network_aai, delete_vserver_aai,
29 query_network_aai, query_vserver_aai)
30 from lcm.pub.msapi.extsys import get_vim_by_id, split_vim_to_owner_region
31 from lcm.pub.utils.values import ignore_case_get
33 logger = logging.getLogger(__name__)
36 class HandleVnfLcmOocNotification(object):
37 def __init__(self, vnfmid, vnfInstanceId, data):
38 logger.debug("[Notify LCM] vnfmid=%s, vnfInstanceId=%s, data=%s" % (vnfmid, vnfInstanceId, data))
40 self.m_vnfInstanceId = vnfInstanceId
41 self.vnf_instid = get_vnfinstid(self.m_vnfInstanceId, self.vnfmid)
42 self.operation = ignore_case_get(data, 'operation')
43 self.affectedVnfcs = ignore_case_get(data, 'affectedVnfcs')
44 self.affectedVls = ignore_case_get(data, 'affectedVirtualLinks')
45 self.affectedCps = ignore_case_get(data, 'changedExtConnectivity')
46 self.affectedVirtualStorage = ignore_case_get(data, 'affectedVirtualStorages')
55 self.update_network_in_aai()
56 logger.debug("notify lcm end")
57 except NSLCMException as e:
60 logger.error(traceback.format_exc())
61 exception('unexpected exception')
63 def update_Vnfc(self):
64 for vnfc in self.affectedVnfcs:
65 vnfcInstanceId = ignore_case_get(vnfc, 'id')
66 vduId = ignore_case_get(vnfc, 'vduId')
67 changeType = ignore_case_get(vnfc, 'changeType')
68 computeResource = ignore_case_get(vnfc, 'computeResource')
69 vimId = ignore_case_get(computeResource, "vimConnectionId")
70 vmId = ignore_case_get(computeResource, 'resourceId')
71 vmName = ignore_case_get(computeResource, 'resourceId') # replaced with resouceId temporarily
73 if changeType == 'ADDED':
74 VNFCInstModel(vnfcinstanceid=vnfcInstanceId, vduid=vduId,
75 nfinstid=self.vnf_instid, vmid=vmId).save()
76 VmInstModel(vmid=vmId, vimid=vimId, resouceid=vmId, insttype=INST_TYPE.VNF,
77 instid=self.vnf_instid, vmname=vmName, hostid='1').save()
79 self.create_vserver_in_aai(vimId, vmId, vmName)
80 elif changeType == 'REMOVED':
82 self.delete_vserver_in_aai(vimId, vmId, vmName)
83 VNFCInstModel.objects.filter(vnfcinstanceid=vnfcInstanceId).delete()
84 elif changeType == 'MODIFIED':
85 VNFCInstModel.objects.filter(vnfcinstanceid=vnfcInstanceId).update(vduid=vduId,
86 nfinstid=self.vnf_instid,
89 exception('affectedVnfc struct error: changeType not in {ADDED, REMOVED, MODIFIED, TEMPORARY}')
90 logger.debug("Success to update all vserver to aai.")
93 for vl in self.affectedVls:
94 vlInstanceId = ignore_case_get(vl, 'id')
95 vldid = ignore_case_get(vl, 'virtualLinkDescId')
96 changeType = ignore_case_get(vl, 'changeType')
97 networkResource = ignore_case_get(vl, 'networkResource')
98 resourceType = ignore_case_get(networkResource, 'vimLevelResourceType')
99 resourceId = ignore_case_get(networkResource, 'resourceId')
100 resourceName = ignore_case_get(networkResource, 'resourceId') # replaced with resouceId temporarily
102 if resourceType != 'network':
103 exception('affectedVl struct error: resourceType not euqal network')
105 ownerId = self.vnf_instid
107 if changeType == 'ADDED':
108 VLInstModel(vlinstanceid=vlInstanceId, vldid=vldid, vlinstancename=resourceName, ownertype=0,
109 ownerid=ownerId, relatednetworkid=resourceId, vltype=0).save()
110 elif changeType == 'REMOVED':
111 VLInstModel.objects.filter(vlinstanceid=vlInstanceId).delete()
112 elif changeType == 'MODIFIED':
113 VLInstModel.objects.filter(vlinstanceid=vlInstanceId)\
114 .update(vldid=vldid, vlinstancename=resourceName, ownertype=0, ownerid=ownerId,
115 relatednetworkid=resourceId, vltype=0)
117 exception('affectedVl struct error: changeType not in {ADDED, REMOVED, MODIFIED, TEMPORARY}')
120 for cp in self.affectedCps:
121 virtualLinkInstanceId = ignore_case_get(cp, 'id')
123 ownerid = self.vnf_instid
124 for extLinkPorts in ignore_case_get(cp, 'extLinkPorts'):
125 cpInstanceId = ignore_case_get(extLinkPorts, 'cpInstanceId')
126 cpdId = ignore_case_get(extLinkPorts, 'id')
127 # changeType = ignore_case_get(cp, 'changeType')
130 portResource = ignore_case_get(extLinkPorts, 'resourceHandle')
132 vimId = ignore_case_get(portResource, 'vimConnectionId')
133 resourceId = ignore_case_get(portResource, 'resourceId')
134 resourceName = ignore_case_get(portResource, 'resourceId') # replaced with resouceId temporarily
135 # tenant = ignore_case_get(portResource, 'tenant')
136 # ipAddress = ignore_case_get(portResource, 'ipAddress')
137 # macAddress = ignore_case_get(portResource, 'macAddress')
138 # instId = ignore_case_get(portResource, 'instId')
139 portid = str(uuid.uuid4())
141 PortInstModel(portid=portid, networkid='unknown', subnetworkid='unknown', vimid=vimId,
142 resourceid=resourceId, name=resourceName, instid="unknown", cpinstanceid=cpInstanceId,
143 bandwidth='unknown', operationalstate='active', ipaddress="unkown",
144 macaddress='unknown',
145 floatipaddress='unknown', serviceipaddress='unknown', typevirtualnic='unknown',
146 sfcencapsulation='gre', direction='unknown', tenant="unkown").save()
147 relatedportId = portid
149 CPInstModel(cpinstanceid=cpInstanceId, cpdid=cpdId, ownertype=ownertype, ownerid=ownerid,
150 vlinstanceid=virtualLinkInstanceId, relatedtype=2, relatedport=relatedportId,
151 status='active').save()
153 def update_Storage(self):
156 def update_network_in_aai(self):
157 logger.debug("update_network_in_aai::begin to report network to aai.")
159 for vl in self.affectedVls:
160 vlInstanceId = ignore_case_get(vl, 'id')
161 # vldid = ignore_case_get(vl, 'vldid')
162 changeType = ignore_case_get(vl, 'changeType')
163 networkResource = ignore_case_get(vl, 'networkResource')
164 resourceType = ignore_case_get(networkResource, 'vimLevelResourceType')
165 # resourceId = ignore_case_get(networkResource, 'resourceId')
167 if resourceType != 'network':
168 logger.error('affectedVl struct error: resourceType not euqal network')
169 raise NSLCMException("affectedVl struct error: resourceType not euqal network")
171 ownerId = self.vnf_instid
173 if changeType in ['ADDED', 'MODIFIED']:
174 self.create_network_and_subnet_in_aai(vlInstanceId, ownerId)
175 elif changeType == 'REMOVED':
176 self.delete_network_and_subnet_in_aai(vlInstanceId)
178 logger.error('affectedVl struct error: changeType not in {ADDED, REMOVED, MODIFIED, TEMPORARY}')
179 except NSLCMException as e:
180 logger.debug("Fail to create internal network to aai, detail message: %s" % e.message)
182 logger.error(traceback.format_exc())
184 def create_network_and_subnet_in_aai(self, vlInstanceId, ownerId):
185 logger.debug("CreateVls::create_network_in_aai::report network[%s] to aai." % vlInstanceId)
188 "network-id": vlInstanceId,
189 "network-name": vlInstanceId,
190 "is-bound-to-vpn": False,
191 "is-provider-network": True,
192 "is-shared-network": True,
193 "is-external-network": True,
194 "relationship-list": {
197 "related-to": "generic-vnf",
198 "relationship-data": [
200 "relationship-key": "generic-vnf.vnf-id",
201 "relationship-value": ownerId
208 resp_data, resp_status = create_network_aai(vlInstanceId, data)
209 logger.debug("Success to create network[%s] to aai: [%s].", vlInstanceId, resp_status)
210 except NSLCMException as e:
211 logger.debug("Fail to create network[%s] to aai, detail message: %s" % (vlInstanceId, e.message))
213 logger.error(traceback.format_exc())
215 def delete_network_and_subnet_in_aai(self, vlInstanceId):
216 logger.debug("DeleteVls::delete_network_in_aai::delete network[%s] in aai." % vlInstanceId)
218 # query network in aai, get resource_version
219 customer_info = query_network_aai(vlInstanceId)
220 resource_version = customer_info["resource-version"]
222 # delete network from aai
223 resp_data, resp_status = delete_network_aai(vlInstanceId, resource_version)
224 logger.debug("Success to delete network[%s] from aai, resp_status: [%s]."
225 % (vlInstanceId, resp_status))
226 except NSLCMException as e:
227 logger.debug("Fail to delete network[%s] to aai, detail message: %s" % (vlInstanceId, e.message))
229 logger.error(traceback.format_exc())
231 def create_vserver_in_aai(self, vim_id, vserver_id, vserver_name):
232 logger.debug("NotifyLcm::create_vserver_in_aai::report vserver instance to aai.")
234 cloud_owner, cloud_region_id = split_vim_to_owner_region(vim_id)
236 # query vim_info from aai
237 vim_info = get_vim_by_id(vim_id)
238 tenant_id = vim_info["tenantId"]
240 "vserver-id": vserver_id,
241 "vserver-name": vserver_name,
242 "prov-status": "ACTIVE",
243 "vserver-selflink": "",
245 "is-closed-loop-disabled": False,
246 "relationship-list": {
249 "related-to": "generic-vnf",
250 "relationship-data": [
252 "relationship-key": "generic-vnf.vnf-id",
253 "relationship-value": self.vnf_instid
261 # create vserver instance in aai
262 resp_data, resp_status = create_vserver_aai(cloud_owner, cloud_region_id, tenant_id, vserver_id, data)
263 logger.debug("Success to create vserver[%s] to aai, vnf instance=[%s], resp_status: [%s]."
264 % (vserver_id, self.vnf_instid, resp_status))
265 except NSLCMException as e:
266 logger.debug("Fail to create vserver to aai, vnf instance=[%s], detail message: %s"
267 % (self.vnf_instid, e.message))
269 logger.error(traceback.format_exc())
271 def delete_vserver_in_aai(self, vim_id, vserver_id, vserver_name):
272 logger.debug("delete_vserver_in_aai start![%s]", vserver_name)
274 cloud_owner, cloud_region_id = split_vim_to_owner_region(vim_id)
275 # query vim_info from aai, get tenant
276 vim_info = get_vim_by_id(vim_id)
277 tenant_id = vim_info["tenantId"]
279 # query vserver instance in aai, get resource_version
280 vserver_info = query_vserver_aai(cloud_owner, cloud_region_id, tenant_id, vserver_id)
281 resource_version = vserver_info["resource-version"]
283 # delete vserver instance from aai
284 resp_data, resp_status = delete_vserver_aai(cloud_owner, cloud_region_id,
285 tenant_id, vserver_id, resource_version)
287 "Success to delete vserver instance[%s] from aai, resp_status: [%s]." %
288 (vserver_id, resp_status))
289 logger.debug("delete_vserver_in_aai end!")
290 except NSLCMException as e:
291 logger.debug("Fail to delete vserver from aai, detail message: %s" % e.message)
293 logger.error(traceback.format_exc())
296 class HandleVnfIdentifierCreationNotification(object):
297 def __init__(self, vnfmId, vnfInstanceId, data):
298 logger.debug("[Notify VNF Identifier Creation] vnfmId=%s, vnfInstanceId=%s, data=%s" % (vnfmId, vnfInstanceId, data))
299 self.vnfm_id = vnfmId
300 self.m_vnf_instance_id = vnfInstanceId
301 self.time_stamp = ignore_case_get(data, 'timeStamp')
302 # TODO: self.subscription_id = ignore_case_get(data, 'subscriptionId')
303 # TODO: self._links = ignore_case_get(data, '_links')
308 nfinstid=str(uuid.uuid4()),
309 mnfinstid=self.m_vnf_instance_id,
310 vnfm_inst_id=self.vnfm_id,
311 create_time=self.time_stamp
313 logger.debug("Notify VNF identifier creation end.")
315 logger.error(traceback.format_exc())
316 exception('unexpected exception')
319 class HandleVnfIdentifierDeletionNotification(object):
320 def __init__(self, vnfmId, vnfInstanceId, data):
321 logger.debug("[Notify VNF Identifier Deletion] vnfmId=%s, vnfInstanceId=%s, data=%s" % (vnfmId, vnfInstanceId, data))
322 self.vnfm_id = vnfmId
323 self.m_vnf_instance_id = vnfInstanceId
324 self.vnf_instance_id = get_vnfinstid(self.m_vnf_instance_id, self.vnfm_id)
325 self.time_stamp = ignore_case_get(data, 'timeStamp')
326 # TODO: self.subscription_id = ignore_case_get(data, 'subscriptionId')
327 # TODO: self._links = ignore_case_get(data, '_links')
331 nf_insts = NfInstModel.objects.filter(
332 mnfinstid=self.m_vnf_instance_id, vnfm_inst_id=self.vnfm_id)
333 if nf_insts.exists():
335 logger.debug("Notify VNF identifier deletion end.")
337 logger.error(traceback.format_exc())
338 exception('unexpected exception')
341 def get_vnfinstid(mnfinstid, vnfm_inst_id):
342 logger.debug("vnfinstid in vnfm is:%s,vnfmid is:%s", mnfinstid, vnfm_inst_id)
343 logger.debug("mnfinstid=%s, vnfm_inst_id=%s", mnfinstid, vnfm_inst_id)
344 nfinst = NfInstModel.objects.filter(mnfinstid=mnfinstid, vnfm_inst_id=vnfm_inst_id).first()
346 return nfinst.nfinstid
347 raise NSLCMException("vnfinstid not exist")
350 def exception(error_msg):
351 logger.error('Notify Lcm failed, detail message: %s' % error_msg)
352 return Response(data={'error': '%s' % error_msg}, status=status.HTTP_409_CONFLICT)