gps303/qry.py

   1 from datetime import datetime, timezone
   2 from sqlite3 import connect
   3 import sys
   4
   5 from .gps303proto import parse_message, proto_by_name
   6
   7 db = connect(sys.argv[1])
   8 c = db.cursor()
   9 if len(sys.argv) > 2:
  10     proto = proto_by_name(sys.argv[2])
  11     if proto < 0:
  12         raise ValueError("No protocol with name " + sys.argv[2])
  13     selector = " where proto = :proto"
  14 else:
  15     proto = -1
  16     selector = ""
  17
  18 c.execute(
  19     "select tstamp, imei, peeraddr, proto, packet from events" + selector,
  20     {"proto": proto},
  21 )
  22
  23 for tstamp, imei, peeraddr, proto, packet in c:
  24     if len(packet) > packet[0] + 1:
  25         print(
  26             "proto",
  27             packet[1],
  28             "datalen",
  29             len(packet),
  30             "msg.length",
  31             packet[0],
  32             file=sys.stderr,
  33         )
  34     msg = parse_message(packet)
  35     print(
  36         datetime.fromtimestamp(tstamp).astimezone(tz=timezone.utc).isoformat(),
  37         imei,
  38         peeraddr,
  39         msg,
  40     )