From 9a2c76a0a360d78203a06f651014d185704713ca Mon Sep 17 00:00:00 2001 From: Jason Michalski Date: Mon, 26 Aug 2024 20:46:14 -0700 Subject: [PATCH] Set an identifier when connecting to MQTT. --- meshview/mqtt_reader.py | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/meshview/mqtt_reader.py b/meshview/mqtt_reader.py index ae62c9b..91d2490 100644 --- a/meshview/mqtt_reader.py +++ b/meshview/mqtt_reader.py @@ -1,5 +1,6 @@ import base64 import asyncio +import random import aiomqtt from google.protobuf.message import DecodeError @@ -27,10 +28,11 @@ def decrypt(packet): async def get_topic_envelopes(mqtt_server, topics): + identifier = str(random.getrandbits(16)) while True: try: async with aiomqtt.Client( - mqtt_server, username="meshdev", password="large4cats" + mqtt_server, username="meshdev", password="large4cats" , identifier=identifier, ) as client: for topic in topics: await client.subscribe(topic)