update nxos mroutes service

Author: scetron

suzieq/poller/worker/services/mroutes.py

@@ -1,6 +1,7 @@
 from suzieq.poller.worker.services.service import Service
 from suzieq.shared.utils import get_timestamp_from_cisco_time
 
+
 class MroutesService(Service):
     """Mroutes service."""
 
@@ -17,40 +18,11 @@ def _fix_star_source(self, entry):
             entry["source"] = "*"
 
     def _common_data_cleaner(self, processed_data, _):
-
         for entry in processed_data:
             self._fix_ipvers(entry)
             self._fix_star_source(entry)
 
         return processed_data
-    
-
-    def _clean_nxos_data(self, processed_data, raw_data):
-        reprocessed_data = {}
-        timestamp = raw_data[0]["timestamp"]
-        for entry in processed_data:
-            unique = "-".join([entry["vrf"], entry["group"]])
-            if unique in reprocessed_data:
-                # don't have duplicate entries
-                if entry["oifList"] not in reprocessed_data[unique]["oifList"]:
-                    reprocessed_data[unique]["oifList"].append(entry["oifList"])
-            else:
-                if not isinstance(entry["oifList"], list):
-                    entry["oifList"] = [entry["oifList"]]
-                reprocessed_data.update(
-                    {
-                        unique: {
-                            "oifList": entry["oifList"],
-                            "group": entry["group"],
-                            "source": entry["source"],
-                            "vrf": entry["vrf"],
-                            "incomingIf": entry["incomingIf"],
-                            "rpfNeighbor": entry["rpfNeighbor"],
-                            "lastUpTime": get_timestamp_from_cisco_time(entry["lastUpTime"], timestamp/1000),
-                        }
-                    }
-                )
-
-                processed_data = list(reprocessed_data.values())
 
+    def _clean_nxos_data(self, processed_data, _):
         return processed_data