From 18cd592f906b22a3ff78e6c5ce399de6fe8035e9 Mon Sep 17 00:00:00 2001
From: Kevin Elliott <kevin@welikeinc.com>
Date: Wed, 17 Jul 2024 19:58:18 -0700
Subject: [PATCH] finally squashed the bug

---
 mqtt.py | 24 ++++++++++++------------
 1 file changed, 12 insertions(+), 12 deletions(-)

diff --git a/mqtt.py b/mqtt.py
index c86b2ec..782e170 100644
--- a/mqtt.py
+++ b/mqtt.py
@@ -256,9 +256,9 @@ async def handle_log(self, msg):
             f.write(f"{msg.payload.decode('utf-8')}\n")
 
     async def handle_neighborinfo(self, msg):
-        msg['from'] = f'{msg["from"]:x}'
+        msg['from'] = utils.convert_node_id_from_int_to_hex(msg["from"])
         if 'to' in msg:
-            msg['to'] = f'{msg["to"]:x}'
+            msg['to'] = utils.convert_node_id_from_int_to_hex(msg["to"])
         if 'sender' in msg and msg['sender'] and isinstance(msg['sender'], str):
             msg['sender'] = msg['sender'].replace('!', '')
 
@@ -276,9 +276,9 @@ async def handle_neighborinfo(self, msg):
         await self.data.save()
 
     async def handle_nodeinfo(self, msg):
-        msg['from'] = f'{msg["from"]:x}'
+        msg['from'] = utils.convert_node_id_from_int_to_hex(msg["from"])
         if 'to' in msg:
-            msg['to'] = f'{msg["to"]:x}'
+            msg['to'] = utils.convert_node_id_from_int_to_hex(msg["to"])
         if 'sender' in msg and msg['sender'] and isinstance(msg['sender'], str):
             msg['sender'] = msg['sender'].replace('!', '')
 
@@ -319,9 +319,9 @@ async def handle_nodeinfo(self, msg):
         await self.data.save()
 
     async def handle_position(self, msg):
-        msg['from'] = f'{msg["from"]:x}'
+        msg['from'] = utils.convert_node_id_from_int_to_hex(msg["from"])
         if 'to' in msg:
-            msg['to'] = f'{msg["to"]:x}'
+            msg['to'] = utils.convert_node_id_from_int_to_hex(msg["to"])
         if 'sender' in msg and msg['sender'] and isinstance(msg['sender'], str):
             msg['sender'] = msg['sender'].replace('!', '')
 
@@ -339,9 +339,9 @@ async def handle_position(self, msg):
         await self.data.save()
 
     async def handle_telemetry(self, msg):
-        msg['from'] = f'{msg["from"]:x}'
+        msg['from'] = utils.convert_node_id_from_int_to_hex(msg["from"])
         if 'to' in msg:
-            msg['to'] = f'{msg["to"]:x}'
+            msg['to'] = utils.convert_node_id_from_int_to_hex(msg["to"])
         if 'sender' in msg and msg['sender'] and isinstance(msg['sender'], str):
             msg['sender'] = msg['sender'].replace('!', '')
 
@@ -367,9 +367,9 @@ async def handle_telemetry(self, msg):
         await self.data.save()
 
     async def handle_text(self, msg):
-        msg['from'] = f'{msg["from"]:x}'
+        msg['from'] = utils.convert_node_id_from_int_to_hex(msg["from"])
         if 'to' in msg:
-            msg['to'] = f'{msg["to"]:x}'
+            msg['to'] = utils.convert_node_id_from_int_to_hex(msg["to"])
         if 'sender' in msg and msg['sender'] and isinstance(msg['sender'], str):
             msg['sender'] = msg['sender'].replace('!', '')
         if 'channel' not in msg:
@@ -398,9 +398,9 @@ async def handle_text(self, msg):
         await self.data.save()
 
     async def handle_traceroute(self, msg):
-        msg['from'] = f'{msg["from"]:x}'
+        msg['from'] = utils.convert_node_id_from_int_to_hex(msg["from"])
         if 'to' in msg:
-            msg['to'] = f'{msg["to"]:x}'
+            msg['to'] = utils.convert_node_id_from_int_to_hex(msg["to"])
         if 'sender' in msg and msg['sender'] and isinstance(msg['sender'], str):
             msg['sender'] = msg['sender'].replace('!', '')
         msg['route'] = msg['payload']['route']