commit 7959e1fd7710fb463412cb15e67abd2780a58aff
author Hardik Windlass <hardik_windlass@infosys.com> Sat Mar 30 20:38:02 2019 +0530
committer Hardik Windlass <hardik_windlass@infosys.com> Wed Apr 10 14:07:51 2019 +0530
tree 9f6554c90d59b0c490c32409a3bffae300c2ad7b
parent 7fc09ed41037e8e7ff6ef14292f86c49a0dbe7ad

[SEBA-297] Standardized onu.events format

Change-Id: Ic487d18bcfe01460e0325d4fb7d87e45280fd2fa

xos/synchronizer/event_steps/onu_event.py

diff --git a/xos/synchronizer/event_steps/onu_event.py b/xos/synchronizer/event_steps/onu_event.py
index 0db61df..bc55f16 100644
--- a/xos/synchronizer/event_steps/onu_event.py
+++ b/xos/synchronizer/event_steps/onu_event.py
@@ -30,18 +30,18 @@
     def get_att_si(self, event):
         try:
             att_si = self.model_accessor.AttWorkflowDriverServiceInstance.objects.get(
-                serial_number=event["serial_number"])
+                serial_number=event["serialNumber"])
             att_si.no_sync = False
-            att_si.uni_port_id = event["uni_port_id"]
-            att_si.of_dpid = event["of_dpid"]
+            att_si.uni_port_id = long(event["portNumber"])
+            att_si.of_dpid = event["deviceId"]
             self.log.debug("onu.events: Found existing AttWorkflowDriverServiceInstance", si=att_si)
         except IndexError:
             # create an AttWorkflowDriverServiceInstance, the validation will be
             # triggered in the corresponding sync step
             att_si = self.model_accessor.AttWorkflowDriverServiceInstance(
-                serial_number=event["serial_number"],
-                of_dpid=event["of_dpid"],
-                uni_port_id=event["uni_port_id"],
+                serial_number=event["serialNumber"],
+                of_dpid=event["deviceId"],
+                uni_port_id=long(event["portNumber"]),
                 # we assume there is only one AttWorkflowDriverService
                 owner=self.model_accessor.AttWorkflowDriverService.objects.first()
             )