External-Mirrors/awx
2
0
Fork 0
mirror of https://github.com/ansible/awx.git synced 2026-05-10 19:07:36 -02:30
Code Issues Packages Projects Releases Wiki Activity

add more logs for network canvas activity

Browse Source
This commit is contained in:
AlanCoding
2018-04-23 15:29:13 -04:00
parent df4f6ecfd6
commit 405a936544
1 changed files with 6 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

7
awx/network_ui/consumers.py
View File

@@ -80,7 +80,7 @@ class NetworkingEvents(object):
type='device_type', type='device_type',
id='cid', id='cid',
host_id='host_id'), device) host_id='host_id'), device)
logger.info("Device %s", device) logger.info("Device created %s", device)
d, _ = Device.objects.get_or_create(topology_id=topology_id, cid=device['cid'], defaults=device) d, _ = Device.objects.get_or_create(topology_id=topology_id, cid=device['cid'], defaults=device)
d.x = device['x'] d.x = device['x']
d.y = device['y'] d.y = device['y']
@@ -92,6 +92,7 @@ class NetworkingEvents(object):
.update(device_id_seq=device['cid'])) .update(device_id_seq=device['cid']))
def onDeviceDestroy(self, device, topology_id, client_id): def onDeviceDestroy(self, device, topology_id, client_id):
logger.info("Device removed %s", device)
Device.objects.filter(topology_id=topology_id, cid=device['id']).delete() Device.objects.filter(topology_id=topology_id, cid=device['id']).delete()
def onDeviceMove(self, device, topology_id, client_id): def onDeviceMove(self, device, topology_id, client_id):
@@ -101,6 +102,7 @@ class NetworkingEvents(object):
Device.objects.filter(topology_id=topology_id, cid=device['id']).update(host_id=device['host_id']) Device.objects.filter(topology_id=topology_id, cid=device['id']).update(host_id=device['host_id'])
def onDeviceLabelEdit(self, device, topology_id, client_id): def onDeviceLabelEdit(self, device, topology_id, client_id):
logger.debug("Device label edited %s", device)
Device.objects.filter(topology_id=topology_id, cid=device['id']).update(name=device['name']) Device.objects.filter(topology_id=topology_id, cid=device['id']).update(name=device['name'])
def onInterfaceLabelEdit(self, interface, topology_id, client_id): def onInterfaceLabelEdit(self, interface, topology_id, client_id):
@@ -111,6 +113,7 @@ class NetworkingEvents(object):
.update(name=interface['name'])) .update(name=interface['name']))
def onLinkLabelEdit(self, link, topology_id, client_id): def onLinkLabelEdit(self, link, topology_id, client_id):
logger.debug("Link label edited %s", link)
Link.objects.filter(from_device__topology_id=topology_id, cid=link['id']).update(name=link['name']) Link.objects.filter(from_device__topology_id=topology_id, cid=link['id']).update(name=link['name'])
def onInterfaceCreate(self, interface, topology_id, client_id): def onInterfaceCreate(self, interface, topology_id, client_id):
@@ -125,6 +128,7 @@ class NetworkingEvents(object):
.update(interface_id_seq=interface['id'])) .update(interface_id_seq=interface['id']))
def onLinkCreate(self, link, topology_id, client_id): def onLinkCreate(self, link, topology_id, client_id):
logger.debug("Link created %s", link)
device_map = dict(Device.objects device_map = dict(Device.objects
.filter(topology_id=topology_id, cid__in=[link['from_device_id'], link['to_device_id']]) .filter(topology_id=topology_id, cid__in=[link['from_device_id'], link['to_device_id']])
.values_list('cid', 'pk')) .values_list('cid', 'pk'))
@@ -141,6 +145,7 @@ class NetworkingEvents(object):
.update(link_id_seq=link['id'])) .update(link_id_seq=link['id']))
def onLinkDestroy(self, link, topology_id, client_id): def onLinkDestroy(self, link, topology_id, client_id):
logger.debug("Link deleted %s", link)
device_map = dict(Device.objects device_map = dict(Device.objects
.filter(topology_id=topology_id, cid__in=[link['from_device_id'], link['to_device_id']]) .filter(topology_id=topology_id, cid__in=[link['from_device_id'], link['to_device_id']])
.values_list('cid', 'pk')) .values_list('cid', 'pk'))