acidvegas/meshtastic-mqtt-json
acidvegas/meshtastic-mqtt-json
1
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases 4 Wiki Activity

Fixed error handling on inproper service envelopes

Browse Source
This commit is contained in:
Dionysus 2024-12-02 21:19:30 -05:00
parent 8ff2e6b04a
commit 8a7b14e017
Signed by: acidvegas
GPG Key ID: EF4B922DB85DC9DE
1 changed files with 11 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

16
src/meshtastic_mqtt_json/client.py
View File

@ -135,15 +135,20 @@ class MeshtasticMQTT(object):
:param client: The client instance for this callback :param client: The client instance for this callback
:param userdata: The private user data as set in Client() or user_data_set() :param userdata: The private user data as set in Client() or user_data_set()
:param msg: An instance of MQTTMessage. This is a :param msg: An instance of MQTTMessage
''' '''
try: try:
# Define the service envelope # Define the service envelope
service_envelope = mqtt_pb2.ServiceEnvelope() service_envelope = mqtt_pb2.ServiceEnvelope()
# Parse the message payload try:
service_envelope.ParseFromString(msg.payload) # Parse the message payload
service_envelope.ParseFromString(msg.payload)
except Exception as e:
print(f'Error parsing service envelope: {e}')
print(f'Raw payload: {msg.payload}')
return
# Extract the message packet from the service envelope # Extract the message packet from the service envelope
mp = service_envelope.packet mp = service_envelope.packet
@ -299,7 +304,8 @@ class MeshtasticMQTT(object):
except Exception as e: except Exception as e:
print(f'Error processing message: {e}') print(f'Error processing message: {e}')
print(mp) print(f'Topic: {msg.topic}')
print(f'Payload: {msg.payload}')
def main(): def main():