while True:
zmsg = Bcast(zsub.recv())
log.debug(
- "IMEI %s from %s at %s: %s",
+ "%s IMEI %s from %s at %s: %s",
+ "I" if zmsg.is_incoming else "O",
zmsg.imei,
zmsg.peeraddr,
datetime.fromtimestamp(zmsg.when).astimezone(tz=timezone.utc),
zmsg.packet.hex(),
)
- if zmsg.peeraddr is not None:
- addr, port = zmsg.peeraddr
- peeraddr = str((str(addr), port))
- else:
- peeraddr = None
stow(
- peeraddr=peeraddr,
+ is_incoming=zmsg.is_incoming,
+ peeraddr=str(zmsg.peeraddr),
when=zmsg.when,
imei=zmsg.imei,
proto=proto_of_message(zmsg.packet),