Changeset 9623 for src/django_gheat/gheat/management/commands/netstumbler.py

Timestamp:

Aug 30, 2011, 6:13:57 PM (13 years ago)

Author:

rick

Message:

Merge and migrate all files into common files to get rid of all duplicate codes.

File:

• src/django_gheat/gheat/management/commands/netstumbler.py (modified) (2 diffs)

src/django_gheat/gheat/management/commands/netstumbler.py

@@ -8 +8 @@
 from struct import unpack
 
-def parse_netstumbler(fh):
+from collections import defaultdict
+import logging
+
+logger = logging.getLogger(__name__)
+logger.setLevel(logging.INFO)
+
+def parse_ns1(fh):
   def get_int32(size=1):
     v = unpack('<' + 'i'*size,fh.read(4*size))
@@ -103 +109 @@
   return data
 
+def process_ns1(fh, counters):
+  data = parse_ns1(fh)
+
+
+  # Temponary holders
+  meting_pool = defaultdict(list)
+  ap_pool = {}
+
+  for ap in data['aps']:
+    # XXX: How is encryption coded?
+    encryption = False
+    ap_pool[ap['BSSID']]= (ap['SSID'], encryption)
+    for point in ap["measurements"]:
+     counters['meting_total'] += 1
+     if point['LocationSource'] == 0:
+       logger.debug("No GPS Coordinates found for BSSID %s @ %s", 
+         ap['BSSID'], point['Time'])
+       counters['meting_ignored'] += 1
+       continue
+     # We store all values found, avg or max will be done later on
+     key = (ap['BSSID'], point["Latitude"], point["Longitude"])
+
+     # Known measurement error
+     if point['Signal'] == -32767: continue
+
+     # XXX: Signal need properly be a relation of signal_dbm and noice_dbm
+     signaal= 100 + point['Signal']
+     if signaal > 100 or signaal < 0:
+       logger.warning("Signal %s is not valid entry for BSSID %s @ %s",
+         point['Signal'], ap['BSSID'], point['Time'])
+       continue
+     meting_pool[key].append(signaal)
+
+  return (counters, ap_pool, None, meting_pool)
 if __name__ == '__main__':
   import sys
   import pprint
   pp = pprint.PrettyPrinter(indent=2)
-  pp.pprint(parse_netstumbler(open(sys.argv[1],'r')))
+  pp.pprint(parse_ns1(open(sys.argv[1],'r')))