X-Git-Url: http://www.average.org/gitweb/?p=loctrkd.git;a=blobdiff_plain;f=gps303%2Fstorage.py;h=b6f84ce993e4356c4e8f32e43946f27bf12ce846;hp=14afc49e1fde494f5aebcf96bb2582f572fe1de7;hb=7f904a11263dc04df2110c36444522ea622367d4;hpb=380ccd781fef5b1ee98e9660c748c8955d3bf40e diff --git a/gps303/storage.py b/gps303/storage.py index 14afc49..b6f84ce 100644 --- a/gps303/storage.py +++ b/gps303/storage.py @@ -1,5 +1,6 @@ """ Store zmq broadcasts to sqlite """ +from configparser import ConfigParser from datetime import datetime, timezone from logging import getLogger import zmq @@ -12,12 +13,13 @@ from .zmsg import Bcast log = getLogger("gps303/storage") -def runserver(conf): +def runserver(conf: ConfigParser) -> None: dbname = conf.get("storage", "dbfn") log.info('Using Sqlite3 database "%s"', dbname) initdb(dbname) - 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, b"")