X-Git-Url: http://average.org/gitweb/?a=blobdiff_plain;f=gps303%2Flookaside.py;h=d05e76990f0229e0ab7b862c620181bbb88a8cfa;hb=b259201054951214f5a8c7980eb2dcd9f3a54498;hp=7655f55e4bb095655b41d525aba89cf0a4b12c87;hpb=1888de5a5dd4bdb85f3fb745341920a9996b278e;p=loctrkd.git diff --git a/gps303/lookaside.py b/gps303/lookaside.py index 7655f55..d05e769 100644 --- a/gps303/lookaside.py +++ b/gps303/lookaside.py @@ -1,5 +1,6 @@ """ Estimate coordinates from WIFI_POSITIONING and send back """ +from configparser import ConfigParser from datetime import datetime, timezone from importlib import import_module from logging import getLogger @@ -14,14 +15,15 @@ from .zmsg import Bcast, Resp, topic log = getLogger("gps303/lookaside") -def runserver(conf): +def runserver(conf: ConfigParser) -> None: qry = import_module("." + conf.get("lookaside", "backend"), __package__) qry.init(conf) - zctx = zmq.Context() - zsub = zctx.socket(zmq.SUB) + # Is this https://github.com/zeromq/pyzmq/issues/1627 still not fixed?! + zctx = zmq.Context() # type: ignore + zsub = zctx.socket(zmq.SUB) # type: ignore zsub.connect(conf.get("collector", "publishurl")) zsub.setsockopt(zmq.SUBSCRIBE, topic(WIFI_POSITIONING.PROTO)) - zpush = zctx.socket(zmq.PUSH) + zpush = zctx.socket(zmq.PUSH) # type: ignore zpush.connect(conf.get("collector", "listenurl")) try: @@ -36,7 +38,9 @@ def runserver(conf): msg, ) try: - lat, lon = qry.lookup(msg.mcc, msg.mnc, msg.gsm_cells, msg.wifi_aps) + lat, lon = qry.lookup( + msg.mcc, msg.mnc, msg.gsm_cells, msg.wifi_aps + ) resp = Resp( imei=zmsg.imei, when=zmsg.when, # not the current time, but the original!