From 4a1737ebd40e1de70c8a8c75f0e072d12c9a2a7e Mon Sep 17 00:00:00 2001 From: Joel Krauska Date: Tue, 7 Oct 2025 20:13:00 -0700 Subject: [PATCH] fix for loranet.pl --- meshview/mqtt_store.py | 10 +++++++++- 1 file changed, 9 insertions(+), 1 deletion(-) diff --git a/meshview/mqtt_store.py b/meshview/mqtt_store.py index 57fe9d2..b4ee710 100644 --- a/meshview/mqtt_store.py +++ b/meshview/mqtt_store.py @@ -96,10 +96,18 @@ async def process_envelope(topic, env): await session.execute(stmt) # --- PacketSeen (no conflict handling here, normal insert) + + if not env.gateway_id: + print("WARNING: Missing gateway_id, skipping PacketSeen entry") + # Most likely a misconfiguration of a mqtt publisher? + return + else: + node_id = int(env.gateway_id[1:], 16) + result = await session.execute( select(PacketSeen).where( PacketSeen.packet_id == env.packet.id, - PacketSeen.node_id == int(env.gateway_id[1:], 16), + PacketSeen.node_id == node_id, PacketSeen.rx_time == env.packet.rx_time, ) )