X-Git-Url: http://www.average.org/gitweb/?a=blobdiff_plain;f=gps303%2Flookaside.py;h=b42ce06f378a5ae10fe9a642475556ab577d6859;hb=3b94b72763b7db9e9665d60c3dd26812bd134a8d;hp=dd5a449bdbcfa771fd5358f25b1d56afd52b386a;hpb=5e1e7a4d37a1e149d5e899dada7b55a863cd8e64;p=loctrkd.git diff --git a/gps303/lookaside.py b/gps303/lookaside.py index dd5a449..b42ce06 100644 --- a/gps303/lookaside.py +++ b/gps303/lookaside.py @@ -15,11 +15,14 @@ log = getLogger("gps303/lookaside") def runserver(conf): + if conf.get("lookaside", "backend") != "opencellid": + raise NotImplementedError( + "Lookaside only implements opencellid backend" + ) zctx = zmq.Context() zsub = zctx.socket(zmq.SUB) zsub.connect(conf.get("collector", "publishurl")) - tosub = topic(WIFI_POSITIONING.PROTO) - zsub.setsockopt(zmq.SUBSCRIBE, tosub) + zsub.setsockopt(zmq.SUBSCRIBE, topic(WIFI_POSITIONING.PROTO)) zpush = zctx.socket(zmq.PUSH) zpush.connect(conf.get("collector", "listenurl")) @@ -39,6 +42,7 @@ def runserver(conf): ) resp = Resp( imei=zmsg.imei, + when=zmsg.when, # not the current time, but the original! packet=msg.Out(latitude=lat, longitude=lon).packed, ) log.debug("Response for lat=%s, lon=%s: %s", lat, lon, resp)