diff service/beacon/rssiscan.py @ 462:7ec5945752b7

some old Measurement and Locator edits Ignore-this: 188ecdf63f49b7a58f99a5961c6c23a6
author drewp@bigasterisk.com
date Sat, 20 Apr 2019 23:35:46 -0700
parents 70755e76bc03
children
line wrap: on
line diff
--- a/service/beacon/rssiscan.py	Sat Apr 20 23:33:39 2019 -0700
+++ b/service/beacon/rssiscan.py	Sat Apr 20 23:35:46 2019 -0700
@@ -176,21 +176,22 @@
                 rows = list(evt_le_advertising_report_dump(pkt))
                 for row in sorted(rows):
                     rssi = row.pop('rssi')
-                    points.append(dict(
-                        measurement='rssi',
-                        tags={'from': source, 'toAddr': row['addr']},
-                        fields={'value': rssi},
-                        time=nowMs,
-                        ))
-                    key = (row['addr'], row['evt_type'])
-                    if lastDoc.get(key) != row:
-                        # should check mongodb here- maybe another
-                        # node already wrote this row
-                        lastDoc.put(key, row)
-                        row = row.copy()
-                        row['t'] = now
-                        coll.insert(row)
-                    
+                    if row['addr_type'] == 'Public': # or, someday, if it's a device we know
+                        points.append(dict(
+                            measurement='rssi',
+                            tags={'from': source, 'toAddr': row['addr']},
+                            fields={'value': rssi},
+                            time=nowMs,
+                            ))
+                        key = (row['addr'], row['evt_type'])
+                        if lastDoc.get(key) != row:
+                            # should check mongodb here- maybe another
+                            # node already wrote this row
+                            lastDoc.put(key, row)
+                            row = row.copy()
+                            row['t'] = now
+                            coll.insert(row)
+
     influx.write_points(points, time_precision='ms')
     sock.setsockopt( bluez.SOL_HCI, bluez.HCI_FILTER, old_filter )