adam/meshview
1
0 Fork 0
mirror of https://github.com/pablorevilla-meshtastic/meshview.git synced 2026-10-31 03:01:58 +01:00
Code Issues 20 Packages Projects Releases Wiki Activity

update

Browse Source
This commit is contained in:
pablorevilla-meshtastic committed 2026-09-10 15:39:55 -07:00
1 parent 325e685209
commit bb8da4cc13
1 file changed
+1 -2
Download Patch File Download Diff File Expand all files Collapse all files
meshview/mqtt_store.py
+1 -2
View File
@@ -23,7 +23,7 @@ MQTT_DIRECT_NODE_ID = 1
def has_valid_location(lat: int | None, lon: int | None) -> bool: def has_valid_location(lat: int | None, lon: int | None) -> bool:
return lat not in (None, 0) and lon not in (None, 0) return lat is not None and lon is not None and abs(lat) > 1 and abs(lon) > 1
def node_user_id(node_id: int) -> str: def node_user_id(node_id: int) -> str:
@@ -217,7 +217,6 @@ async def process_envelope(topic, env):
async with mqtt_database.async_session() as session: async with mqtt_database.async_session() as session:
# --- Packet insert with ON CONFLICT DO NOTHING # --- Packet insert with ON CONFLICT DO NOTHING
from_node_id = getattr(env.packet, "from", None) from_node_id = getattr(env.packet, "from", None)
await ensure_node_exists(session, from_node_id, env.channel_id)
result = await session.execute(select(Packet).where(Packet.id == packet_id)) result = await session.execute(select(Packet).where(Packet.id == packet_id))
packet = result.scalar_one_or_none() packet = result.scalar_one_or_none()