+ if channel == "NfDeploymentStateChanged":
+ datastr = m['data']
+ data = json.loads(datastr)
+ logger.info('HandleNfDeploymentStateChanged with cmd:{}'.format(data))
+ cmd = commands.HandleNfDeploymentStateChanged(
+ NfDeploymentId=data['NfDeploymentId'],
+ FromState=data['FromState'],
+ ToState=data['ToState']
+ )
+ bus.handle(cmd)
+ elif channel == 'ResourceTypeChanged':
+ datastr = m['data']
+ data = json.loads(datastr)
+ logger.info('ResourceTypeChanged with cmd:{}'.format(data))
+ ref = apibase + inventory_api_version + '/resourceTypes/' + \
+ data['id']
+ cmd = imscmd.PubMessage2SMO(data=Message2SMO(
+ id=data['id'], ref=ref,
+ eventtype=data['notificationEventType'],
+ updatetime=data['updatetime']),
+ type='ResourceType')
+ bus.handle(cmd)
+ elif channel == 'ResourcePoolChanged':
+ datastr = m['data']
+ data = json.loads(datastr)
+ logger.info('ResourcePoolChanged with cmd:{}'.format(data))
+ ref = apibase + inventory_api_version + '/resourcePools/' + \
+ data['id']
+ cmd = imscmd.PubMessage2SMO(data=Message2SMO(
+ id=data['id'], ref=ref,
+ eventtype=data['notificationEventType'],
+ updatetime=data['updatetime']),
+ type='ResourcePool')
+ bus.handle(cmd)
+ elif channel == 'DmsChanged':
+ datastr = m['data']
+ data = json.loads(datastr)
+ logger.info('ResourceChanged with cmd:{}'.format(data))
+ ref = apibase + inventory_api_version + '/deploymentManagers/' + \
+ data['id']
+ cmd = imscmd.PubMessage2SMO(data=Message2SMO(
+ id=data['id'], ref=ref,
+ eventtype=data['notificationEventType'],
+ updatetime=data['updatetime']),
+ type='Dms')
+ bus.handle(cmd)
+ elif channel == 'ResourceChanged':
+ datastr = m['data']
+ data = json.loads(datastr)
+ logger.info('ResourceChanged with cmd:{}'.format(data))
+ ref = apibase + inventory_api_version + '/resourcePools/' + \
+ data['resourcePoolId'] + '/resources/' + data['id']
+ cmd = imscmd.PubMessage2SMO(data=Message2SMO(
+ id=data['id'], ref=ref,
+ eventtype=data['notificationEventType'],
+ updatetime=data['updatetime']),
+ type='Resource')
+ bus.handle(cmd)
+ elif channel == 'OcloudChanged':
+ datastr = m['data']
+ data = json.loads(datastr)
+ logger.info('OcloudChanged with cmd:{}'.format(data))
+ cmd = imscmd.Register2SMO(data=RegistrationMessage(
+ id=data['id'], eventtype=data['notificationEventType'],
+ updatetime=data['updatetime']))
+ bus.handle(cmd)
+ elif channel == 'AlarmEventChanged':