X-Git-Url: http://average.org/gitweb/?a=blobdiff_plain;f=gps303%2Ftermconfig.py;fp=gps303%2Ftermconfig.py;h=0000000000000000000000000000000000000000;hb=dbdf9d63af31770ad57302e16b17a2fdc526773f;hp=4599dc2ed181c1d4a8d463135c295a56a60f53be;hpb=bf48ccad4b4b91e7d7e09d1087f5953bc2db97d7;p=loctrkd.git

diff --git a/gps303/termconfig.py b/gps303/termconfig.py
deleted file mode 100644
index 4599dc2..0000000
--- a/gps303/termconfig.py
+++ /dev/null
@@ -1,85 +0,0 @@
-""" For when responding to the terminal is not trivial """
-
-from configparser import ConfigParser
-from datetime import datetime, timezone
-from logging import getLogger
-from struct import pack
-import zmq
-
-from . import common
-from .zx303proto import *
-from .zmsg import Bcast, Resp, topic
-
-log = getLogger("gps303/termconfig")
-
-
-def runserver(conf: ConfigParser) -> None:
-    # 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"))
-    for proto in (
-        proto_name(STATUS),
-        proto_name(SETUP),
-        proto_name(POSITION_UPLOAD_INTERVAL),
-    ):
-        zsub.setsockopt(zmq.SUBSCRIBE, topic(proto))
-    zpush = zctx.socket(zmq.PUSH)  # type: ignore
-    zpush.connect(conf.get("collector", "listenurl"))
-
-    try:
-        while True:
-            zmsg = Bcast(zsub.recv())
-            msg = parse_message(zmsg.packet)
-            log.debug(
-                "IMEI %s from %s at %s: %s",
-                zmsg.imei,
-                zmsg.peeraddr,
-                datetime.fromtimestamp(zmsg.when).astimezone(tz=timezone.utc),
-                msg,
-            )
-            if msg.RESPOND is not Respond.EXT:
-                log.error(
-                    "%s does not expect externally provided response", msg
-                )
-            if zmsg.imei is not None and conf.has_section(zmsg.imei):
-                termconfig = common.normconf(conf[zmsg.imei])
-            elif conf.has_section("termconfig"):
-                termconfig = common.normconf(conf["termconfig"])
-            else:
-                termconfig = {}
-            kwargs = {}
-            if isinstance(msg, STATUS):
-                kwargs = {
-                    "upload_interval": termconfig.get(
-                        "statusintervalminutes", 25
-                    )
-                }
-            elif isinstance(msg, SETUP):
-                for key in (
-                    "uploadintervalseconds",
-                    "binaryswitch",
-                    "alarms",
-                    "dndtimeswitch",
-                    "dndtimes",
-                    "gpstimeswitch",
-                    "gpstimestart",
-                    "gpstimestop",
-                    "phonenumbers",
-                ):
-                    if key in termconfig:
-                        kwargs[key] = termconfig[key]
-            resp = Resp(
-                imei=zmsg.imei, when=zmsg.when, packet=msg.Out(**kwargs).packed
-            )
-            log.debug("Response: %s", resp)
-            zpush.send(resp.packed)
-
-    except KeyboardInterrupt:
-        zsub.close()
-        zpush.close()
-        zctx.destroy()  # type: ignore
-
-
-if __name__.endswith("__main__"):
-    runserver(common.init(log))