Update route control script. Still need to address issue with core …

…interface

conf/route_control.py

@@ -604,25 +604,25 @@ def _get_gate_idx(self, route_entry: RouteEntry, module_name: str) -> int:
         return self._module_gate_count_cache[module_name]
 
     def _netlink_event_listener(
-        self, netlink_message: dict, action: str
+        self, ndb: NDB, netlink_message: dict
     ) -> None:
         """Listens for netlink events and handles them.
 
         Args:
             netlink_message (dict): The netlink message.
-            action (str): The action.
         """
-        logger.info("%s netlink event received.", action)
+        event = netlink_message['event']
+        logger.info("%s netlink event received.", event)
         route_entry = self._parse_route_entry_msg(netlink_message)
-        if action == KEY_NEW_ROUTE_ACTION and route_entry:
+        if event == KEY_NEW_ROUTE_ACTION and route_entry:
             with self._lock:
                 self.add_new_route_entry(route_entry)
 
-        elif action == KEY_DELETE_ROUTE_ACTION and route_entry:
+        elif event == KEY_DELETE_ROUTE_ACTION and route_entry:
             with self._lock:
                 self.delete_route_entry(route_entry)
 
-        elif action == KEY_NEW_NEIGHBOR_ACTION:
+        elif event == KEY_NEW_NEIGHBOR_ACTION:
             with self._lock:
                 self.add_unresolved_new_neighbor(netlink_message)
 

conf/test_route_control.py

@@ -367,7 +367,7 @@ def test_given_netlink_message_when_rtm_newroute_event_then_add_new_route_entry_
             "event": "RTM_NEWROUTE",
         }
         self.route_controller._netlink_event_listener(
-            example_route_entry, "RTM_NEWROUTE"
+            self.ndb, example_route_entry
         )
         mock_add_new_route_entry.assert_called()
 
@@ -443,7 +443,7 @@ def test_given_netlink_message_when_rtm_delroute_event_then_delete_route_entry_i
             "event": "RTM_DELROUTE",
         }
         self.route_controller._netlink_event_listener(
-            example_route_entry, "RTM_DELROUTE"
+            self.ndb, example_route_entry
         )
         mock_delete_route_entry.assert_called()
 
@@ -481,6 +481,6 @@ def test_given_netlink_message_when_rtm_newneigh_event_then_add_unresolved_new_n
         self, mock_add_unresolved_new_neighbor
     ):
         self.route_controller._netlink_event_listener(
-            "new neighbour message", "RTM_NEWNEIGH"
+            self.ndb, "new neighbour message"
         )
         mock_add_unresolved_new_neighbor.assert_called()