Create read_messages_tcp.py

Author: brad28b

read_messages_tcp.py

@@ -0,0 +1,75 @@
+import time
+import sys
+from pubsub import pub
+from meshtastic.tcp_interface import TCPInterface
+from meshtastic import portnums_pb2
+
+node_ip = '192.168.1.125'  # Replace with your Meshtastic node's IP address
+
+def get_node_info(node_ip):
+    print("Initializing TcpInterface to get node info...")
+    local = TCPInterface(hostname=node_ip)
+    node_info = local.nodes
+    local.close()
+    print("Node info retrieved.")
+    return node_info
+
+def parse_node_info(node_info):
+    print("Parsing node info...")
+    nodes = []
+    for node_id, node in node_info.items():
+        nodes.append({
+            'num': node_id,
+            'user': {
+                'shortName': node.get('user', {}).get('shortName', 'Unknown')
+            }
+        })
+    print("Node info parsed.")
+    return nodes
+
+def on_receive(packet, interface, node_list):
+    try:
+        if packet['decoded'].get('portnum') == 'TEXT_MESSAGE_APP':
+            message = packet['decoded']['payload'].decode('utf-8')
+            fromnum = packet['fromId']
+            shortname = next((node['user']['shortName'] for node in node_list if node['num'] == fromnum), 'Unknown')
+            print(f"{shortname}: {message}")
+    except KeyError:
+        pass  # Ignore KeyError silently
+    except UnicodeDecodeError:
+        pass  # Ignore UnicodeDecodeError silently
+
+def main():
+    print(f"Using node IP: {node_ip}")
+
+    # Retrieve and parse node information
+    node_info = get_node_info(node_ip)
+    node_list = parse_node_info(node_info)
+
+    # Print node list for debugging
+    print("Node List:")
+    for node in node_list:
+        print(node)
+
+    # Subscribe the callback function to message reception
+    def on_receive_wrapper(packet, interface):
+        on_receive(packet, interface, node_list)
+
+    pub.subscribe(on_receive_wrapper, "meshtastic.receive")
+    print("Subscribed to meshtastic.receive")
+
+    # Set up the TcpInterface for message listening
+    local = TCPInterface(hostname=node_ip)
+    print("TcpInterface setup for listening.")
+
+    # Keep the script running to listen for messages
+    try:
+        while True:
+            sys.stdout.flush()
+            time.sleep(1)  # Sleep to reduce CPU usage
+    except KeyboardInterrupt:
+        print("Script terminated by user")
+        local.close()
+
+if __name__ == "__main__":
+    main()