X-Git-Url: http://www.average.org/gitweb/?p=loctrkd.git;a=blobdiff_plain;f=gps303%2Flookaside.py;h=fb976a00acfd1a968aded27af08d72f4883faf17;hp=7655f55e4bb095655b41d525aba89cf0a4b12c87;hb=c4c37b80c38009b8e93d9e06705d400b325f6d2a;hpb=7f904a11263dc04df2110c36444522ea622367d4 diff --git a/gps303/lookaside.py b/gps303/lookaside.py index 7655f55..fb976a0 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: