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.
20 from rest_framework import status
21 from rest_framework.response import Response
23 from lcm.ns_vnfs.enum import INST_TYPE
24 from lcm.pub.config.config import REPORT_TO_AAI
25 from lcm.pub.database.models import (CPInstModel, NfInstModel, PortInstModel,
26 VLInstModel, VmInstModel, VNFCInstModel)
27 from lcm.pub.exceptions import NSLCMException, RequestException
28 from lcm.pub.msapi.aai import (create_network_aai, create_vserver_aai,
29 delete_network_aai, delete_vserver_aai,
30 query_network_aai, query_vserver_aai)
31 from lcm.pub.msapi.extsys import get_vim_by_id, split_vim_to_owner_region
32 from lcm.pub.utils.values import ignore_case_get
34 logger = logging.getLogger(__name__)
37 class HandleVnfLcmOocNotification(object):
38 def __init__(self, vnfmid, vnfInstanceId, data):
39 logger.debug("[Notify LCM] vnfmid=%s, vnfInstanceId=%s, data=%s" % (vnfmid, vnfInstanceId, data))
41 self.m_vnfInstanceId = vnfInstanceId
42 self.vnf_instid = get_vnfinstid(self.m_vnfInstanceId, self.vnfmid)
43 self.operation = ignore_case_get(data, 'operation')
44 self.affectedVnfcs = ignore_case_get(data, 'affectedVnfcs')
45 self.affectedVls = ignore_case_get(data, 'affectedVirtualLinks')
46 self.affectedCps = ignore_case_get(data, 'changedExtConnectivity')
47 self.affectedVirtualStorage = ignore_case_get(data, 'affectedVirtualStorages')
56 self.update_network_in_aai()
57 logger.debug("notify lcm end")
58 except NSLCMException as e:
61 logger.error(traceback.format_exc())
62 exception('unexpected exception')
64 def update_Vnfc(self):
65 for vnfc in self.affectedVnfcs:
66 vnfcInstanceId = ignore_case_get(vnfc, 'id')
67 vduId = ignore_case_get(vnfc, 'vduId')
68 changeType = ignore_case_get(vnfc, 'changeType')
69 computeResource = ignore_case_get(vnfc, 'computeResource')
70 vimId = ignore_case_get(computeResource, "vimConnectionId")
71 vmId = ignore_case_get(computeResource, 'resourceId')
72 vmName = ignore_case_get(computeResource, 'resourceId') # replaced with resouceId temporarily
74 if changeType == 'ADDED':
75 VNFCInstModel(vnfcinstanceid=vnfcInstanceId, vduid=vduId,
76 nfinstid=self.vnf_instid, vmid=vmId).save()
77 VmInstModel(vmid=vmId, vimid=vimId, resouceid=vmId, insttype=INST_TYPE.VNF,
78 instid=self.vnf_instid, vmname=vmName, hostid='1').save()
80 self.create_vserver_in_aai(vimId, vmId, vmName)
81 elif changeType == 'REMOVED':
83 self.delete_vserver_in_aai(vimId, vmId, vmName)
84 VNFCInstModel.objects.filter(vnfcinstanceid=vnfcInstanceId).delete()
85 elif changeType == 'MODIFIED':
86 VNFCInstModel.objects.filter(vnfcinstanceid=vnfcInstanceId).update(vduid=vduId,
87 nfinstid=self.vnf_instid,
90 exception('affectedVnfc struct error: changeType not in {ADDED, REMOVED, MODIFIED, TEMPORARY}')
91 logger.debug("Success to update all vserver to aai.")
94 for vl in self.affectedVls:
95 vlInstanceId = ignore_case_get(vl, 'id')
96 vldid = ignore_case_get(vl, 'virtualLinkDescId')
97 changeType = ignore_case_get(vl, 'changeType')
98 networkResource = ignore_case_get(vl, 'networkResource')
99 resourceType = ignore_case_get(networkResource, 'vimLevelResourceType')
100 resourceId = ignore_case_get(networkResource, 'resourceId')
101 resourceName = ignore_case_get(networkResource, 'resourceId') # replaced with resouceId temporarily
103 if resourceType != 'network':
104 exception('affectedVl struct error: resourceType not euqal network')
106 ownerId = self.vnf_instid
108 if changeType == 'ADDED':
109 VLInstModel(vlinstanceid=vlInstanceId, vldid=vldid, vlinstancename=resourceName, ownertype=0,
110 ownerid=ownerId, relatednetworkid=resourceId, vltype=0).save()
111 elif changeType == 'REMOVED':
112 VLInstModel.objects.filter(vlinstanceid=vlInstanceId).delete()
113 elif changeType == 'MODIFIED':
114 VLInstModel.objects.filter(vlinstanceid=vlInstanceId)\
115 .update(vldid=vldid, vlinstancename=resourceName, ownertype=0, ownerid=ownerId,
116 relatednetworkid=resourceId, vltype=0)
118 exception('affectedVl struct error: changeType not in {ADDED, REMOVED, MODIFIED, TEMPORARY}')
121 for cp in self.affectedCps:
122 # virtualLinkInstanceId = ignore_case_get(cp, 'id')
124 ownerid = self.vnf_instid
125 for extLinkPorts in ignore_case_get(cp, 'extLinkPorts'):
126 cpInstanceId = ignore_case_get(extLinkPorts, 'cpInstanceId')
127 cpdId = ignore_case_get(extLinkPorts, 'id')
128 # changeType = ignore_case_get(cp, 'changeType')
131 portResource = ignore_case_get(extLinkPorts, 'resourceHandle')
133 vimId = ignore_case_get(portResource, 'vimConnectionId')
134 resourceId = ignore_case_get(portResource, 'resourceId')
135 resourceName = ignore_case_get(portResource, 'resourceId') # replaced with resouceId temporarily
136 tenant = ignore_case_get(portResource, 'tenant')
137 ipAddress = ignore_case_get(portResource, 'ipAddress')
138 macAddress = ignore_case_get(portResource, 'macAddress')
139 instId = ignore_case_get(portResource, 'instId')
140 portid = ignore_case_get(portResource, 'portId')
141 networkId = ignore_case_get(portResource, 'networkId')
142 subnetId = ignore_case_get(portResource, 'subnetId')
144 # portid = str(uuid.uuid4())
146 PortInstModel(portid=portid, networkid=networkId, subnetworkid=subnetId, vimid=vimId,
147 resourceid=resourceId, name=resourceName, instid=instId, cpinstanceid=cpInstanceId,
148 bandwidth='unknown', operationalstate='active', ipaddress=ipAddress,
149 macaddress=macAddress,
150 floatipaddress='unknown', serviceipaddress='unknown', typevirtualnic='unknown',
151 sfcencapsulation='gre', direction='unknown', tenant=tenant).save()
152 relatedportId = portid
154 CPInstModel(cpinstanceid=cpInstanceId, cpdid=cpdId, ownertype=ownertype, ownerid=ownerid,
155 relatedtype=2, relatedport=relatedportId, status='active').save()
157 def update_Storage(self):
160 def update_network_in_aai(self):
161 logger.debug("update_network_in_aai::begin to report network to aai.")
163 for vl in self.affectedVls:
164 vlInstanceId = ignore_case_get(vl, 'id')
165 # vldid = ignore_case_get(vl, 'vldid')
166 changeType = ignore_case_get(vl, 'changeType')
167 networkResource = ignore_case_get(vl, 'networkResource')
168 resourceType = ignore_case_get(networkResource, 'vimLevelResourceType')
169 # resourceId = ignore_case_get(networkResource, 'resourceId')
171 if resourceType != 'network':
172 logger.error('affectedVl struct error: resourceType not euqal network')
173 raise NSLCMException("affectedVl struct error: resourceType not euqal network")
175 ownerId = self.vnf_instid
177 if changeType in ['ADDED', 'MODIFIED']:
178 self.create_network_and_subnet_in_aai(vlInstanceId, ownerId)
179 elif changeType == 'REMOVED':
180 self.delete_network_and_subnet_in_aai(vlInstanceId)
182 logger.error('affectedVl struct error: changeType not in {ADDED, REMOVED, MODIFIED, TEMPORARY}')
183 except NSLCMException as e:
184 logger.debug("Fail to create internal network to aai, detail message: %s" % e.args[0])
186 logger.error(traceback.format_exc())
188 def create_network_and_subnet_in_aai(self, vlInstanceId, ownerId):
189 logger.debug("CreateVls::create_network_in_aai::report network[%s] to aai." % vlInstanceId)
192 "network-id": vlInstanceId,
193 "network-name": vlInstanceId,
194 "is-bound-to-vpn": False,
195 "is-provider-network": True,
196 "is-shared-network": True,
197 "is-external-network": True,
198 "relationship-list": {
201 "related-to": "generic-vnf",
202 "relationship-data": [
204 "relationship-key": "generic-vnf.vnf-id",
205 "relationship-value": ownerId
212 resp_data, resp_status = create_network_aai(vlInstanceId, data)
213 logger.debug("Success to create network[%s] to aai: [%s].", vlInstanceId, resp_status)
214 except NSLCMException as e:
215 logger.debug("Fail to create network[%s] to aai, detail message: %s" % (vlInstanceId, e.args[0]))
217 logger.error(traceback.format_exc())
219 def delete_network_and_subnet_in_aai(self, vlInstanceId):
220 logger.debug("DeleteVls::delete_network_in_aai::delete network[%s] in aai." % vlInstanceId)
222 # query network in aai, get resource_version
223 customer_info = query_network_aai(vlInstanceId)
225 resource_version = customer_info["resource-version"]
227 # delete network from aai
228 resp_data, resp_status = delete_network_aai(vlInstanceId, resource_version)
229 logger.debug("Success to delete network[%s] from aai, resp_status: [%s]."
230 % (vlInstanceId, resp_status))
231 except RequestException:
232 logger.debug("Network has been delted in aai")
233 except NSLCMException as e:
234 logger.debug("Fail to delete network[%s] to aai, detail message: %s" % (vlInstanceId, e.args[0]))
236 logger.error(traceback.format_exc())
238 def create_vserver_in_aai(self, vim_id, vserver_id, vserver_name):
239 logger.debug("NotifyLcm::create_vserver_in_aai::report vserver instance to aai.")
241 cloud_owner, cloud_region_id = split_vim_to_owner_region(vim_id)
243 # query vim_info from aai
244 vim_info = get_vim_by_id({"cloud_owner": cloud_owner, 'cloud_regionid': cloud_region_id})
245 tenant_id = vim_info["tenantId"]
247 "vserver-id": vserver_id,
248 "vserver-name": vserver_name,
249 "prov-status": "ACTIVE",
250 "vserver-selflink": "",
252 "is-closed-loop-disabled": False,
253 "relationship-list": {
256 "related-to": "generic-vnf",
257 "relationship-data": [
259 "relationship-key": "generic-vnf.vnf-id",
260 "relationship-value": self.vnf_instid
268 # create vserver instance in aai
269 resp_data, resp_status = create_vserver_aai(cloud_owner, cloud_region_id, tenant_id, vserver_id, data)
270 logger.debug("Success to create vserver[%s] to aai, vnf instance=[%s], resp_status: [%s]."
271 % (vserver_id, self.vnf_instid, resp_status))
272 except NSLCMException as e:
273 logger.debug("Fail to create vserver to aai, vnf instance=[%s], detail message: %s"
274 % (self.vnf_instid, e.args[0]))
276 logger.error(traceback.format_exc())
278 def delete_vserver_in_aai(self, vim_id, vserver_id, vserver_name):
279 logger.debug("delete_vserver_in_aai start![%s]", vserver_name)
281 cloud_owner, cloud_region_id = split_vim_to_owner_region(vim_id)
282 # query vim_info from aai, get tenant
283 vim_info = get_vim_by_id({"cloud_owner": cloud_owner, 'cloud_regionid': cloud_region_id})
284 tenant_id = vim_info["tenantId"]
286 # query vserver instance in aai, get resource_version
287 vserver_info = query_vserver_aai(cloud_owner, cloud_region_id, tenant_id, vserver_id)
289 resource_version = vserver_info["resource-version"]
291 # delete vserver instance from aai
292 resp_data, resp_status = delete_vserver_aai(cloud_owner, cloud_region_id,
293 tenant_id, vserver_id, resource_version)
295 "Success to delete vserver instance[%s] from aai, resp_status: [%s]." %
296 (vserver_id, resp_status))
297 logger.debug("delete_vserver_in_aai end!")
298 except RequestException:
299 logger.debug("Vserver has been deleted from aai")
300 except NSLCMException as e:
301 logger.debug("Fail to delete vserver from aai, detail message: %s" % e.args[0])
303 logger.error(traceback.format_exc())
306 class HandleVnfIdentifierCreationNotification(object):
307 def __init__(self, vnfmId, vnfInstanceId, data):
308 logger.debug("[Notify VNF Identifier Creation] vnfmId=%s, vnfInstanceId=%s, data=%s" % (vnfmId, vnfInstanceId, data))
309 self.vnfm_id = vnfmId
310 self.m_vnf_instance_id = vnfInstanceId
311 self.time_stamp = ignore_case_get(data, 'timeStamp')
312 # TODO: self.subscription_id = ignore_case_get(data, 'subscriptionId')
313 # TODO: self._links = ignore_case_get(data, '_links')
318 nfinstid=str(uuid.uuid4()),
319 mnfinstid=self.m_vnf_instance_id,
320 vnfm_inst_id=self.vnfm_id,
321 create_time=self.time_stamp
323 logger.debug("Notify VNF identifier creation end.")
325 logger.error(traceback.format_exc())
326 exception('unexpected exception')
329 class HandleVnfIdentifierDeletionNotification(object):
330 def __init__(self, vnfmId, vnfInstanceId, data):
331 logger.debug("[Notify VNF Identifier Deletion] vnfmId=%s, vnfInstanceId=%s, data=%s" % (vnfmId, vnfInstanceId, data))
332 self.vnfm_id = vnfmId
333 self.m_vnf_instance_id = vnfInstanceId
334 self.vnf_instance_id = get_vnfinstid(self.m_vnf_instance_id, self.vnfm_id)
335 self.time_stamp = ignore_case_get(data, 'timeStamp')
336 # TODO: self.subscription_id = ignore_case_get(data, 'subscriptionId')
337 # TODO: self._links = ignore_case_get(data, '_links')
341 nf_insts = NfInstModel.objects.filter(
342 mnfinstid=self.m_vnf_instance_id, vnfm_inst_id=self.vnfm_id)
343 if nf_insts.exists():
345 logger.debug("Notify VNF identifier deletion end.")
347 logger.error(traceback.format_exc())
348 exception('unexpected exception')
351 def get_vnfinstid(mnfinstid, vnfm_inst_id):
352 logger.debug("vnfinstid in vnfm is:%s,vnfmid is:%s", mnfinstid, vnfm_inst_id)
353 logger.debug("mnfinstid=%s, vnfm_inst_id=%s", mnfinstid, vnfm_inst_id)
354 nfinst = NfInstModel.objects.filter(mnfinstid=mnfinstid, vnfm_inst_id=vnfm_inst_id).first()
356 return nfinst.nfinstid
357 raise NSLCMException("vnfinstid not exist")
360 def exception(error_msg):
361 logger.error('Notify Lcm failed, detail message: %s' % error_msg)
362 return Response(data={'error': '%s' % error_msg}, status=status.HTTP_409_CONFLICT)