+
+ def prepareNotificationData(self, status, opState, err=None):
+ affected_vnfcs = []
+ if status == LCM_NOTIFICATION_STATUS.RESULT and opState == OPERATION_STATE_TYPE.COMPLETED:
+ vnfcs = VNFCInstModel.objects.filter(instid=self.nf_inst_id)
+ for vnfc in vnfcs:
+ vm_resource = {}
+ if vnfc.vmid:
+ vm = VmInstModel.objects.filter(vmid=vnfc.vmid)
+ if vm:
+ vm_resource = {
+ 'vimConnectionId': vm[0].vimid,
+ 'resourceId': vm[0].resourceid,
+ 'vimLevelResourceType': 'vm'
+ }
+ affected_vnfcs.append({
+ 'id': vnfc.vnfcinstanceid,
+ 'vduId': vnfc.vduid,
+ 'changeType': CHANGE_TYPE.MODIFIED,
+ 'computeResource': vm_resource
+ })
+ notification_content = {
+ "id": str(uuid.uuid4()),
+ "notificationType": "VnfLcmOperationOccurrenceNotification",
+ "subscriptionId": "",
+ "timeStamp": now_time(),
+ "notificationStatus": status,
+ "operationState": opState,
+ "vnfInstanceId": self.nf_inst_id,
+ "operation": OPERATION_TYPE.OPERATE,
+ "isAutomaticInvocation": "false",
+ "vnfLcmOpOccId": self.job_id,
+ "affectedVnfcs": affected_vnfcs,
+ "affectedVirtualLinks": [],
+ "affectedVirtualStorages": [],
+ "changedInfo": {},
+ "changedExtConnectivity": [],
+ "_links": {"vnfInstance": {"href": ""},
+ "subscription": {"href": ""},
+ "vnfLcmOpOcc": {"href": ""}}
+ }
+ if opState in (OPERATION_STATE_TYPE.FAILED, OPERATION_STATE_TYPE.FAILED_TEMP):
+ notification_content["error"] = {"status": 500, "detail": err}
+ notification_content["_links"]["vnfInstance"]["href"] = "/vnf_instances/%s" % self.nf_inst_id
+ notification_content["_links"]["vnfLcmOpOcc"]["href"] = "/vnf_lc_ops/%s" % self.job_id
+ return notification_content