X-Git-Url: http://average.org/gitweb/?a=blobdiff_plain;f=loctrkd%2Fzmsg.py;h=da0dc77e39da6f38d7eaefe5adbdfe897f928b28;hb=148c0b3bdecfd52371506c348c17e1f2c2fdb137;hp=9dae60540f46019957a72121700c6ada5df081de;hpb=be1de0bb68c5c4acf2edd6f04c5ea8e40d9f31fb;p=loctrkd.git diff --git a/loctrkd/zmsg.py b/loctrkd/zmsg.py index 9dae605..da0dc77 100644 --- a/loctrkd/zmsg.py +++ b/loctrkd/zmsg.py @@ -4,7 +4,7 @@ import ipaddress as ip from struct import pack, unpack from typing import Any, cast, Optional, Tuple, Type, Union -__all__ = "Bcast", "Resp", "topic" +__all__ = "Bcast", "Resp", "topic", "rtopic" def pack_peer( # 18 bytes @@ -100,6 +100,10 @@ def topic( ) +def rtopic(imei: str) -> bytes: + return pack("16s", imei.encode()) + + class Bcast(_Zmsg): """Zmq message to broadcast what was received from the terminal""" @@ -168,7 +172,7 @@ class Resp(_Zmsg): self.packet = buffer[24:] -class Report(_Zmsg): +class Rept(_Zmsg): """Broadcast Zzmq message with "rectified" proto-agnostic json data""" KWARGS = (("imei", None), ("payload", ""))