Merge pull request #10 from mirceaulinic/CF-NTP-STATS

NTP stats getter from previously get_ntp_peers()

Author: dbarrosop

.travis.yml

@@ -28,7 +28,7 @@ script:
 - nosetests -v TestJunOSDriver:TestGetterJunOSDriver.test_get_lldp_neighbors
 - nosetests -v TestJunOSDriver:TestGetterJunOSDriver.test_get_lldp_neighbors_detail
 - nosetests -v TestJunOSDriver:TestGetterJunOSDriver.test_get_arp_table
-- nosetests -v TestJunOSDriver:TestGetterJunOSDriver.test_get_ntp_peers
+- nosetests -v TestJunOSDriver:TestGetterJunOSDriver.test_get_ntp_stats
 - nosetests -v TestJunOSDriver:TestGetterJunOSDriver.test_get_interfaces_ip
 - nosetests -v TestJunOSDriver:TestGetterJunOSDriver.test_get_mac_address_table
 - nosetests -v TestJunOSDriver:TestGetterJunOSDriver.test_get_route_to

napalm_junos/junos.py

@@ -721,13 +721,13 @@ def get_arp_table(self):
 
         return arp_table
 
-    def get_ntp_peers(self):
+    def get_ntp_stats(self):
 
         # NTP Peers does not have XML RPC defined
         # thus we need to retrieve raw text and parse...
         # :(
 
-        ntp_peers = dict()
+        ntp_stats = list()
 
         REGEX = (
             '^\s?(\+|\*|x|-)?([a-zA-Z0-9\.+-:]+)'
@@ -746,7 +746,9 @@ def get_ntp_peers(self):
                 continue # pattern not found
             line_groups = line_search.groups()
             try:
-                ntp_peers[unicode(line_groups[1])] = {
+                ntp_stats.append({
+                    'remote'        : unicode(line_groups[1]),
+                    'synchronized'  : (line_groups[0] == '*'),
                     'referenceid'   : unicode(line_groups[2]),
                     'stratum'       : int(line_groups[3]),
                     'type'          : unicode(line_groups[4]),
@@ -756,11 +758,11 @@ def get_ntp_peers(self):
                     'delay'         : float(line_groups[8]),
                     'offset'        : float(line_groups[9]),
                     'jitter'        : float(line_groups[10])
-                }
+                })
             except Exception:
                 continue # jump to next line
 
-        return ntp_peers
+        return ntp_stats
 
     def get_interfaces_ip(self):