Merge pull request #3 from clearpathrobotics/CORE-1738

CORE-1738: wireless_watcher dies

Author: mikepurvis

wireless_watcher/nodes/watcher_node

@@ -26,23 +26,19 @@ class Connection(wireless_msgs.msg.Connection):
     def __init__(self, fields):
         args = {}
 
-        args['bitrate'] = trim(fields['Bit Rate'], float)
-
-        try: args['txpower'] = trim(fields['Tx-Power'])
-        except: pass
-
-        args['link_quality_raw'] = fields['Link Quality']
-        num, den = re.split('/', args['link_quality_raw']) 
-        args['link_quality'] = float(num) / float(den)
-
-        args['signal_level'] = trim(fields['Signal level'])
-
-        try: args['noise_level'] = trim(fields['Noise level'])
+        args['bitrate'] = trim(fields.get('Bit Rate', "0.0"), float)
+        args['txpower'] = trim(fields.get('Tx-Power', "0"))
+        args['signal_level'] = trim(fields.get('Signal level', "0"))
+        args['noise_level'] = trim(fields.get('Noise level', "0"))
+        args['essid'] = fields.get('ESSID', "").strip('"')
+        args['bssid'] = fields.get('Access Point', "").strip()
+
+        try:
+          args['link_quality_raw'] = fields['Link Quality']
+          num, den = re.split('/', args['link_quality_raw'])
+          args['link_quality'] = float(num) / float(den)
         except: pass
 
-        args['essid'] = fields['ESSID'].strip('"')
-        args['bssid'] = fields['Access Point'].strip()
-
         super(Connection, self).__init__(**args)
 
 class Network(wireless_msgs.msg.Network):
@@ -72,8 +68,12 @@ while not rospy.is_shutdown():
     fields_list = [re.split('[:=]', field_str, maxsplit=1) for field_str in fields_str]
     fields_dict = { 'dev': fields_str[0], 'type': fields_str[1] }
     fields_dict.update(dict([field for field in fields_list if len(field) == 2 ]))
-    #print fields_dict
-    connection_msg = Connection(fields_dict)
+
+    # Check if WiFi is connected to a network
+    connection_msg = {}
+    if "Not-Associated" not in fields_dict['Access Point']:
+      connection_msg = Connection(fields_dict)
+
     connection_pub.publish(connection_msg)
 
     if not previous_success: