33from suzieq .poller .worker .services .service import Service
44from suzieq .shared .utils import get_timestamp_from_cisco_time , parse_relative_timestamp
55
6+
67class IgmpService (Service ):
78 """Igmp Service."""
89
@@ -28,24 +29,32 @@ def _clean_eos_data(self, _, raw_data):
2829 # dynamic group "show ip igmp groups" cmd output
2930 if "groupList" in json_data :
3031 for entry in json_data ["groupList" ]:
31- processed_data .append ({
32- "group" : entry ["groupAddress" ],
33- "interface" : entry ["interfaceName" ],
34- "lastUpTime" : parse_relative_timestamp (str (entry ["uptime" ]), cmd_timestamp / 1000 ),
35- "vrf" : vrf ,
36- "flag" : "dynamic"
37- })
32+ processed_data .append (
33+ {
34+ "group" : entry ["groupAddress" ],
35+ "interface" : entry ["interfaceName" ],
36+ "lastUpTime" : parse_relative_timestamp (
37+ str (entry ["uptime" ]), cmd_timestamp / 1000
38+ ),
39+ "vrf" : vrf ,
40+ "flag" : "dynamic" ,
41+ }
42+ )
3843 # static group "show ip igmp static-groups" cmd output
3944 if "intfAddrs" in json_data :
4045 for interface in json_data ["intfAddrs" ]:
41- for group in json_data ["intfAddrs" ][interface ]["groupAddrsList" ]:
42- processed_data .append ({
43- "group" : group ["groupAddr" ],
44- "interface" : interface ,
45- "lastUpTime" : "n/a" ,
46- "vrf" : vrf ,
47- "flag" : "static"
48- })
46+ for group in json_data ["intfAddrs" ][interface ][
47+ "groupAddrsList"
48+ ]:
49+ processed_data .append (
50+ {
51+ "group" : group ["groupAddr" ],
52+ "interface" : interface ,
53+ "lastUpTime" : "n/a" ,
54+ "vrf" : vrf ,
55+ "flag" : "static" ,
56+ }
57+ )
4958
5059 return processed_data
5160
@@ -56,12 +65,14 @@ def _clean_nxos_data(self, processed_data, raw_data):
5665
5766 for entry in processed_data :
5867 if not entry .get ("flag" ):
59- entry .update ({"flag" : ' n/a' })
68+ entry .update ({"flag" : " n/a" })
6069 else :
6170 if "D" in entry ["flag" ]:
62- entry ["flag" ] = "Dynamic "
71+ entry ["flag" ] = "dynamic "
6372 elif "S" in entry ["flag" ]:
64- entry ["flag" ] = "Static"
65- entry ["lastUpTime" ] = get_timestamp_from_cisco_time (entry ["lastUpTime" ], timestamp / 1000 )
73+ entry ["flag" ] = "static"
74+ entry ["lastUpTime" ] = get_timestamp_from_cisco_time (
75+ entry ["lastUpTime" ], timestamp / 1000
76+ )
6677
6778 return processed_data
0 commit comments