gps303/watch.py

   1 """ Watch for locevt and print them """
   2
   3 from datetime import datetime, timezone
   4 from logging import getLogger
   5 import zmq
   6
   7 from . import common
   8 from .zmsg import LocEvt
   9
  10 log = getLogger("gps303/watch")
  11
  12
  13 def runserver(conf):
  14     zctx = zmq.Context()
  15     zsub = zctx.socket(zmq.SUB)
  16     zsub.connect(conf.get("lookaside", "publishurl"))
  17     zsub.setsockopt(zmq.SUBSCRIBE, b"")
  18
  19     try:
  20         while True:
  21             zmsg = LocEvt(zsub.recv())
  22             print(zmsg)
  23     except KeyboardInterrupt:
  24         pass
  25
  26
  27 if __name__.endswith("__main__"):
  28     runserver(common.init(log))