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.
18 from rest_framework import status
19 from rest_framework.response import Response
21 from lcm.pub.config.config import REPORT_TO_AAI
22 from lcm.pub.database.models import VNFCInstModel, VLInstModel, NfInstModel, PortInstModel, CPInstModel, VmInstModel
23 from lcm.pub.exceptions import NSLCMException
24 from lcm.pub.msapi.aai import create_network_aai, query_network_aai, delete_network_aai, query_vserver_aai, \
26 from lcm.pub.msapi.aai import create_vserver_aai
27 from lcm.pub.msapi.extsys import split_vim_to_owner_region, get_vim_by_id
28 from lcm.pub.utils.values import ignore_case_get
29 from lcm.ns_vnfs.enum import INST_TYPE
31 logger = logging.getLogger(__name__)
34 class NotifyLcm(object):
35 def __init__(self, vnfmid, vnfInstanceId, data):
36 logger.debug("[Notify LCM] vnfmid=%s, vnfInstanceId=%s, data=%s" % (vnfmid, vnfInstanceId, data))
39 self.m_vnfInstanceId = vnfInstanceId
40 self.status = ignore_case_get(data, 'status')
41 self.operation = ignore_case_get(data, 'operation')
42 self.lcm_jobid = ignore_case_get(data, 'jobId')
43 self.vnfdmodule = ignore_case_get(data, 'vnfdmodule')
44 self.affectedVnfc = ignore_case_get(data, 'affectedVnfc')
45 self.affectedVl = ignore_case_get(data, 'affectedVl')
46 self.affectedCp = ignore_case_get(data, 'affectedCp')
47 self.affectedVirtualStorage = ignore_case_get(data, 'affectedVirtualStorage')
51 self.vnf_instid = self.get_vnfinstid(self.m_vnfInstanceId, self.vnfmid)
57 self.update_network_in_aai()
58 logger.debug("notify lcm end")
59 except NSLCMException as e:
60 self.exception(e.args[0])
62 logger.error(traceback.format_exc())
63 self.exception('unexpected exception')
65 def get_vnfinstid(self, mnfinstid, vnfm_inst_id):
66 logger.debug("vnfinstid in vnfm is:%s,vnfmid is:%s", mnfinstid, vnfm_inst_id)
67 logger.debug("mnfinstid=%s, vnfm_inst_id=%s", mnfinstid, vnfm_inst_id)
68 nfinst = NfInstModel.objects.filter(mnfinstid=mnfinstid, vnfm_inst_id=vnfm_inst_id).first()
70 return nfinst.nfinstid
71 raise NSLCMException("vnfinstid not exist")
73 def exception(self, error_msg):
74 logger.error('Notify Lcm failed, detail message: %s' % error_msg)
75 return Response(data={'error': '%s' % error_msg}, status=status.HTTP_409_CONFLICT)
77 def update_Vnfc(self):
78 for vnfc in self.affectedVnfc:
79 vnfcInstanceId = ignore_case_get(vnfc, 'vnfcInstanceId')
80 vduId = ignore_case_get(vnfc, 'vduId')
81 changeType = ignore_case_get(vnfc, 'changeType')
82 vimId = ignore_case_get(vnfc, 'vimId')
83 vmId = ignore_case_get(vnfc, 'vmId')
84 vmName = ignore_case_get(vnfc, 'vmName')
86 if changeType == 'added':
87 VNFCInstModel(vnfcinstanceid=vnfcInstanceId, vduid=vduId,
88 nfinstid=self.vnf_instid, vmid=vmId).save()
89 VmInstModel(vmid=vmId, vimid=vimId, resouceid=vmId, insttype=INST_TYPE.VNF,
90 instid=self.vnf_instid, vmname=vmName, hostid='1').save()
92 self.create_vserver_in_aai(vimId, vmId, vmName)
93 elif changeType == 'removed':
95 self.delete_vserver_in_aai(vimId, vmId, vmName)
96 VNFCInstModel.objects.filter(vnfcinstanceid=vnfcInstanceId).delete()
97 elif changeType == 'modified':
98 VNFCInstModel.objects.filter(vnfcinstanceid=vnfcInstanceId).update(vduid=vduId,
99 nfinstid=self.vnf_instid,
102 self.exception('affectedVnfc struct error: changeType not in {added,removed,modified}')
103 logger.debug("Success to update all vserver to aai.")
105 def delete_vserver_in_aai(self, vim_id, vserver_id, vserver_name):
106 logger.debug("delete_vserver_in_aai start![%s]", vserver_name)
108 cloud_owner, cloud_region_id = split_vim_to_owner_region(vim_id)
109 # query vim_info from aai, get tenant
110 vim_info = get_vim_by_id({"cloud_owner": cloud_owner, 'cloud_regionid': cloud_region_id})
111 tenant_id = vim_info["tenantId"]
113 # query vserver instance in aai, get resource_version
114 vserver_info = query_vserver_aai(cloud_owner, cloud_region_id, tenant_id, vserver_id)
115 resource_version = vserver_info["resource-version"]
117 # delete vserver instance from aai
118 resp_data, resp_status = delete_vserver_aai(cloud_owner, cloud_region_id,
119 tenant_id, vserver_id, resource_version)
121 "Success to delete vserver instance[%s] from aai, resp_status: [%s]." %
122 (vserver_id, resp_status))
123 logger.debug("delete_vserver_in_aai end!")
124 except NSLCMException as e:
125 logger.debug("Fail to delete vserver from aai, detail message: %s" % e.args[0])
127 logger.error(traceback.format_exc())
130 for vl in self.affectedVl:
131 vlInstanceId = ignore_case_get(vl, 'vlInstanceId')
132 vldid = ignore_case_get(vl, 'vldId')
133 changeType = ignore_case_get(vl, 'changeType')
134 networkResource = ignore_case_get(vl, 'networkResource')
135 resourceType = ignore_case_get(networkResource, 'resourceType')
136 resourceId = ignore_case_get(networkResource, 'resourceId')
137 resourceName = ignore_case_get(networkResource, 'resourceName')
139 if resourceType != 'network':
140 self.exception('affectedVl struct error: resourceType not euqal network')
142 ownerId = self.get_vnfinstid(self.m_vnfInstanceId, self.vnfmid)
144 if changeType == 'added':
145 VLInstModel(vlinstanceid=vlInstanceId, vldid=vldid, vlinstancename=resourceName, ownertype=0,
146 ownerid=ownerId, relatednetworkid=resourceId, vltype=0).save()
147 elif changeType == 'removed':
148 VLInstModel.objects.filter(vlinstanceid=vlInstanceId).delete()
149 elif changeType == 'modified':
150 VLInstModel.objects.filter(vlinstanceid=vlInstanceId)\
151 .update(vldid=vldid, vlinstancename=resourceName, ownertype=0, ownerid=ownerId,
152 relatednetworkid=resourceId, vltype=0)
154 self.exception('affectedVl struct error: changeType not in {added,removed,modified}')
157 for cp in self.affectedCp:
158 virtualLinkInstanceId = ignore_case_get(cp, 'virtualLinkInstanceId')
159 ownertype = ignore_case_get(cp, 'ownerType')
162 ownerid = self.vnf_instid if str(ownertype) == "0" else ignore_case_get(cp, 'ownerId')
163 cpInstanceId = ignore_case_get(cp, 'cpInstanceId')
164 cpdId = ignore_case_get(cp, 'cpdId')
165 changeType = ignore_case_get(cp, 'changeType')
167 portResource = ignore_case_get(cp, 'portResource')
169 vimId = ignore_case_get(portResource, 'vimId')
170 resourceId = ignore_case_get(portResource, 'resourceId')
171 resourceName = ignore_case_get(portResource, 'resourceName')
172 tenant = ignore_case_get(portResource, 'tenant')
173 ipAddress = ignore_case_get(portResource, 'ipAddress')
174 macAddress = ignore_case_get(portResource, 'macAddress')
175 instId = ignore_case_get(portResource, 'instId')
176 portid = str(uuid.uuid4())
177 PortInstModel(portid=portid, networkid='unknown', subnetworkid='unknown', vimid=vimId,
178 resourceid=resourceId, name=resourceName, instid=instId, cpinstanceid=cpInstanceId,
179 bandwidth='unknown', operationalstate='active', ipaddress=ipAddress, macaddress=macAddress,
180 floatipaddress='unknown', serviceipaddress='unknown', typevirtualnic='unknown',
181 sfcencapsulation='gre', direction='unknown', tenant=tenant).save()
182 relatedportId = portid
184 if changeType == 'added':
185 CPInstModel(cpinstanceid=cpInstanceId, cpdid=cpdId, ownertype=ownertype, ownerid=ownerid,
186 relatedtype=2, relatedport=relatedportId, status='active').save()
187 elif changeType == 'removed':
188 CPInstModel.objects.filter(cpinstanceid=cpInstanceId).delete()
189 elif changeType == 'changed':
190 CPInstModel.objects.filter(cpinstanceid=cpInstanceId).update(cpdid=cpdId, ownertype=ownertype,
192 vlinstanceid=virtualLinkInstanceId,
193 relatedtype=2, relatedport=relatedportId)
195 self.exception('affectedVl struct error: changeType not in {added,removed,modified}')
197 def update_Storage(self):
200 def update_vnf_by_vnfdmodule(self):
201 NfInstModel.objects.filter(nfinstid=self.vnf_instid).update(vnfd_model=self.vnfdmodule)
203 def update_network_in_aai(self):
204 logger.debug("update_network_in_aai::begin to report network to aai.")
206 for vl in self.affectedVl:
207 vlInstanceId = ignore_case_get(vl, 'vlInstanceId')
208 # vldid = ignore_case_get(vl, 'vldid')
209 changeType = ignore_case_get(vl, 'changeType')
210 networkResource = ignore_case_get(vl, 'networkResource')
211 resourceType = ignore_case_get(networkResource, 'resourceType')
212 # resourceId = ignore_case_get(networkResource, 'resourceId')
214 if resourceType != 'network':
215 logger.error('affectedVl struct error: resourceType not euqal network')
216 raise NSLCMException("affectedVl struct error: resourceType not euqal network")
218 ownerId = self.get_vnfinstid(self.m_vnfInstanceId, self.vnfmid)
220 if changeType in ['added', 'modified']:
221 self.create_network_and_subnet_in_aai(vlInstanceId, ownerId)
222 elif changeType == 'removed':
223 self.delete_network_and_subnet_in_aai(vlInstanceId)
225 logger.error('affectedVl struct error: changeType not in {added,removed,modified}')
226 except NSLCMException as e:
227 logger.debug("Fail to create internal network to aai, detail message: %s" % e.args[0])
229 logger.error(traceback.format_exc())
231 def create_network_and_subnet_in_aai(self, vlInstanceId, ownerId):
232 logger.debug("CreateVls::create_network_in_aai::report network[%s] to aai." % vlInstanceId)
235 "network-id": vlInstanceId,
236 "network-name": vlInstanceId,
237 "is-bound-to-vpn": False,
238 "is-provider-network": True,
239 "is-shared-network": True,
240 "is-external-network": True,
241 "relationship-list": {
244 "related-to": "generic-vnf",
245 "relationship-data": [
247 "relationship-key": "generic-vnf.vnf-id",
248 "relationship-value": ownerId
255 resp_data, resp_status = create_network_aai(vlInstanceId, data)
256 logger.debug("Success to create network[%s] to aai: [%s].", vlInstanceId, resp_status)
257 except NSLCMException as e:
258 logger.debug("Fail to create network[%s] to aai, detail message: %s" % (vlInstanceId, e.args[0]))
260 logger.error(traceback.format_exc())
262 def delete_network_and_subnet_in_aai(self, vlInstanceId):
263 logger.debug("DeleteVls::delete_network_in_aai::delete network[%s] in aai." % vlInstanceId)
265 # query network in aai, get resource_version
266 customer_info = query_network_aai(vlInstanceId)
267 resource_version = customer_info["resource-version"]
269 # delete network from aai
270 resp_data, resp_status = delete_network_aai(vlInstanceId, resource_version)
271 logger.debug("Success to delete network[%s] from aai, resp_status: [%s]."
272 % (vlInstanceId, resp_status))
273 except NSLCMException as e:
274 logger.debug("Fail to delete network[%s] to aai, detail message: %s" % (vlInstanceId, e.args[0]))
276 logger.error(traceback.format_exc())
278 def create_vserver_in_aai(self, vim_id, vserver_id, vserver_name):
279 logger.debug("NotifyLcm::create_vserver_in_aai::report vserver instance to aai.")
281 cloud_owner, cloud_region_id = split_vim_to_owner_region(vim_id)
283 # query vim_info from aai
284 vim_info = get_vim_by_id({"cloud_owner": cloud_owner, 'cloud_regionid': cloud_region_id})
285 tenant_id = vim_info["tenantId"]
287 "vserver-id": vserver_id,
288 "vserver-name": vserver_name,
289 "prov-status": "ACTIVE",
290 "vserver-selflink": "",
292 "is-closed-loop-disabled": False,
293 "relationship-list": {
296 "related-to": "generic-vnf",
297 "relationship-data": [
299 "relationship-key": "generic-vnf.vnf-id",
300 "relationship-value": self.vnf_instid
308 # create vserver instance in aai
309 resp_data, resp_status = create_vserver_aai(cloud_owner, cloud_region_id, tenant_id, vserver_id, data)
310 logger.debug("Success to create vserver[%s] to aai, vnf instance=[%s], resp_status: [%s]."
311 % (vserver_id, self.vnf_instid, resp_status))
312 except NSLCMException as e:
313 logger.debug("Fail to create vserver to aai, vnf instance=[%s], detail message: %s"
314 % (self.vnf_instid, e.args[0]))
316 logger.error(traceback.format_exc())