lcm/ns_vnfs/biz/notify_lcm.py

   1 # Copyright 2016 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 import logging
  15 import traceback
  16 import uuid
  17
  18 from rest_framework import status
  19 from rest_framework.response import Response
  20
  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, \
  25     delete_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
  30
  31 logger = logging.getLogger(__name__)
  32
  33
  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))
  37         self.vnf_instid = ''
  38         self.vnfmid = vnfmid
  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')
  48
  49     def do_biz(self):
  50         try:
  51             self.vnf_instid = self.get_vnfinstid(self.m_vnfInstanceId, self.vnfmid)
  52             self.update_Vnfc()
  53             self.update_Vl()
  54             self.update_Cp()
  55             self.update_Storage()
  56             if REPORT_TO_AAI:
  57                 self.update_network_in_aai()
  58             logger.debug("notify lcm end")
  59         except NSLCMException as e:
  60             self.exception(e.args[0])
  61         except Exception:
  62             logger.error(traceback.format_exc())
  63             self.exception('unexpected exception')
  64
  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()
  69         if nfinst:
  70             return nfinst.nfinstid
  71         raise NSLCMException("vnfinstid not exist")
  72
  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)
  76
  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')
  85
  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()
  91                 if REPORT_TO_AAI:
  92                     self.create_vserver_in_aai(vimId, vmId, vmName)
  93             elif changeType == 'REMOVED':
  94                 if REPORT_TO_AAI:
  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,
 100                                                                                    vmid=vmId)
 101             else:
 102                 self.exception('affectedVnfc struct error: changeType not in {added,removed,modified}')
 103         logger.debug("Success to update all vserver to aai.")
 104
 105     def delete_vserver_in_aai(self, vim_id, vserver_id, vserver_name):
 106         logger.debug("delete_vserver_in_aai start![%s]", vserver_name)
 107         try:
 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"]
 112
 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"]
 116
 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)
 120             logger.debug(
 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])
 126         except:
 127             logger.error(traceback.format_exc())
 128
 129     def update_Vl(self):
 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')
 138
 139             if resourceType != 'network':
 140                 self.exception('affectedVl struct error: resourceType not euqal network')
 141
 142             ownerId = self.get_vnfinstid(self.m_vnfInstanceId, self.vnfmid)
 143
 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)
 153             else:
 154                 self.exception('affectedVl struct error: changeType not in {added,removed,modified}')
 155
 156     def update_Cp(self):
 157         for cp in self.affectedCp:
 158             # virtualLinkInstanceId = ignore_case_get(cp, 'virtualLinkInstanceId')
 159             ownertype = ignore_case_get(cp, 'ownerType')
 160             if not ownertype:
 161                 ownertype = 0
 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')
 166             relatedportId = ''
 167             portResource = ignore_case_get(cp, 'portResource')
 168             if 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
 183
 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 == 'MODIFIED':
 190                 CPInstModel.objects.filter(cpinstanceid=cpInstanceId).update(cpdid=cpdId, ownertype=ownertype,
 191                                                                              ownerid=ownerid,
 192                                                                              relatedtype=2, relatedport=relatedportId)
 193             else:
 194                 self.exception('affectedVl struct error: changeType not in {added,removed,modified}')
 195
 196     def update_Storage(self):
 197         pass
 198
 199     def update_vnf_by_vnfdmodule(self):
 200         NfInstModel.objects.filter(nfinstid=self.vnf_instid).update(vnfd_model=self.vnfdmodule)
 201
 202     def update_network_in_aai(self):
 203         logger.debug("update_network_in_aai::begin to report network to aai.")
 204         try:
 205             for vl in self.affectedVl:
 206                 vlInstanceId = ignore_case_get(vl, 'vlInstanceId')
 207                 # vldid = ignore_case_get(vl, 'vldid')
 208                 changeType = ignore_case_get(vl, 'changeType')
 209                 networkResource = ignore_case_get(vl, 'networkResource')
 210                 resourceType = ignore_case_get(networkResource, 'resourceType')
 211                 # resourceId = ignore_case_get(networkResource, 'resourceId')
 212
 213                 if resourceType != 'network':
 214                     logger.error('affectedVl struct error: resourceType not euqal network')
 215                     raise NSLCMException("affectedVl struct error: resourceType not euqal network")
 216
 217                 ownerId = self.get_vnfinstid(self.m_vnfInstanceId, self.vnfmid)
 218
 219                 if changeType in ['added', 'modified']:
 220                     self.create_network_and_subnet_in_aai(vlInstanceId, ownerId)
 221                 elif changeType == 'removed':
 222                     self.delete_network_and_subnet_in_aai(vlInstanceId)
 223                 else:
 224                     logger.error('affectedVl struct error: changeType not in {added,removed,modified}')
 225         except NSLCMException as e:
 226             logger.debug("Fail to create internal network to aai, detail message: %s" % e.args[0])
 227         except:
 228             logger.error(traceback.format_exc())
 229
 230     def create_network_and_subnet_in_aai(self, vlInstanceId, ownerId):
 231         logger.debug("CreateVls::create_network_in_aai::report network[%s] to aai." % vlInstanceId)
 232         try:
 233             data = {
 234                 "network-id": vlInstanceId,
 235                 "network-name": vlInstanceId,
 236                 "is-bound-to-vpn": False,
 237                 "is-provider-network": True,
 238                 "is-shared-network": True,
 239                 "is-external-network": True,
 240                 "relationship-list": {
 241                     "relationship": [
 242                         {
 243                             "related-to": "generic-vnf",
 244                             "relationship-data": [
 245                                 {
 246                                     "relationship-key": "generic-vnf.vnf-id",
 247                                     "relationship-value": ownerId
 248                                 }
 249                             ]
 250                         }
 251                     ]
 252                 }
 253             }
 254             resp_data, resp_status = create_network_aai(vlInstanceId, data)
 255             logger.debug("Success to create network[%s] to aai: [%s].", vlInstanceId, resp_status)
 256         except NSLCMException as e:
 257             logger.debug("Fail to create network[%s] to aai, detail message: %s" % (vlInstanceId, e.args[0]))
 258         except:
 259             logger.error(traceback.format_exc())
 260
 261     def delete_network_and_subnet_in_aai(self, vlInstanceId):
 262         logger.debug("DeleteVls::delete_network_in_aai::delete network[%s] in aai." % vlInstanceId)
 263         try:
 264             # query network in aai, get resource_version
 265             customer_info = query_network_aai(vlInstanceId)
 266             resource_version = customer_info["resource-version"]
 267
 268             # delete network from aai
 269             resp_data, resp_status = delete_network_aai(vlInstanceId, resource_version)
 270             logger.debug("Success to delete network[%s] from aai, resp_status: [%s]."
 271                          % (vlInstanceId, resp_status))
 272         except NSLCMException as e:
 273             logger.debug("Fail to delete network[%s] to aai, detail message: %s" % (vlInstanceId, e.args[0]))
 274         except:
 275             logger.error(traceback.format_exc())
 276
 277     def create_vserver_in_aai(self, vim_id, vserver_id, vserver_name):
 278         logger.debug("NotifyLcm::create_vserver_in_aai::report vserver instance to aai.")
 279         try:
 280             cloud_owner, cloud_region_id = split_vim_to_owner_region(vim_id)
 281
 282             # query vim_info from aai
 283             vim_info = get_vim_by_id({"cloud_owner": cloud_owner, 'cloud_regionid': cloud_region_id})
 284             tenant_id = vim_info["tenantId"]
 285             data = {
 286                 "vserver-id": vserver_id,
 287                 "vserver-name": vserver_name,
 288                 "prov-status": "ACTIVE",
 289                 "vserver-selflink": "",
 290                 "in-maint": True,
 291                 "is-closed-loop-disabled": False,
 292                 "relationship-list": {
 293                     "relationship": [
 294                         {
 295                             "related-to": "generic-vnf",
 296                             "relationship-data": [
 297                                 {
 298                                     "relationship-key": "generic-vnf.vnf-id",
 299                                     "relationship-value": self.vnf_instid
 300                                 }
 301                             ]
 302                         }
 303                     ]
 304                 }
 305             }
 306
 307             # create vserver instance in aai
 308             resp_data, resp_status = create_vserver_aai(cloud_owner, cloud_region_id, tenant_id, vserver_id, data)
 309             logger.debug("Success to create vserver[%s] to aai, vnf instance=[%s], resp_status: [%s]."
 310                          % (vserver_id, self.vnf_instid, resp_status))
 311         except NSLCMException as e:
 312             logger.debug("Fail to create vserver to aai, vnf instance=[%s], detail message: %s"
 313                          % (self.vnf_instid, e.args[0]))
 314         except:
 315             logger.error(traceback.format_exc())