add -info option that prints device information about the node

TODO.md

@@ -2,7 +2,7 @@
 
 ## Before beta
 
-- add fromId and toId to received messages dictionaries
+- make command line options for displaying/changing config
 - update nodedb as nodes change
 - radioConfig - getter/setter syntax: https://www.python-course.eu/python3_properties.php
 - let user change radio params via commandline options
@@ -34,4 +34,4 @@
 - DONE make docs decent
 - DONE keep everything in dicts
 - DONE have device send a special packet at boot so the serial client can detect if it rebooted
-
+- DONE add fromId and toId to received messages dictionaries

meshtastic/__init__.py

@@ -62,7 +62,7 @@ HEADER_LEN = 4
 MAX_TO_FROM_RADIO_SIZE = 512
 
 BROADCAST_ADDR = "all"  # A special ID that means broadcast
-
+BROADCAST_NUM = 255
 
 MY_CONFIG_ID = 42
 
@@ -111,7 +111,7 @@ class MeshInterface:
 
         if isinstance(destinationId, int):
             nodeNum = destinationId
-        elif nodenum == BROADCAST_ADDR:
+        elif nodeNum == BROADCAST_ADDR:
             nodeNum = 255
         else:
             raise Exception(
@@ -124,13 +124,13 @@ class MeshInterface:
     def _disconnected(self):
         """Called by subclasses to tell clients this interface has disconnected"""
         self.isConnected = False
-        pub.sendMessage("meshtastic.connection.lost")
+        pub.sendMessage("meshtastic.connection.lost", interface=self)
 
     def _connected(self):
         """Called by this class to tell clients we are now fully connected to a node
         """
         self.isConnected = True
-        pub.sendMessage("meshtastic.connection.established")
+        pub.sendMessage("meshtastic.connection.established", interface=self)
 
     def _startConfig(self):
         """Start device packets flowing"""
@@ -175,6 +175,16 @@ class MeshInterface:
         else:
             logging.warn("Unexpected FromRadio payload")
 
+    def _nodeNumToId(self, num):
+        if num == BROADCAST_NUM:
+            return BROADCAST_ADDR
+
+        try:
+            return self._nodesByNum[num].user.id
+        except:
+            logging.error("Node not found for fromId")
+            return None
+
     def _handlePacketFromRadio(self, meshPacket):
         """Handle a MeshPacket that just arrived from the radio
 
@@ -183,15 +193,21 @@ class MeshInterface:
         - meshtastic.receive.user(packet = MeshPacket dictionary)
         - meshtastic.receive.data(packet = MeshPacket dictionary)
         """
-        # FIXME, update node DB as needed
+
         asDict = google.protobuf.json_format.MessageToDict(meshPacket)
+        # /add fromId and toId fields based on the node ID
+        asDict["fromId"] = self._nodeNumToId(asDict["from"])
+        asDict["toId"] = self._nodeNumToId(asDict["to"])
+
         # We could provide our objects as DotMaps - which work with . notation or as dictionaries
         #asObj = DotMap(asDict)
         topic = None
         if meshPacket.payload.HasField("position"):
             topic = "meshtastic.receive.position"
+            # FIXME, update node DB as needed
         if meshPacket.payload.HasField("user"):
             topic = "meshtastic.receive.user"
+            # FIXME, update node DB as needed
         if meshPacket.payload.HasField("data"):
             topic = "meshtastic.receive.data"
             # For text messages, we go ahead and decode the text to ascii for our users
@@ -253,7 +269,8 @@ class StreamInterface(MeshInterface):
         logging.debug("Closing serial stream")
         # pyserial cancel_read doesn't seem to work, therefore we ask the reader thread to close things for us
         self._wantExit = True
-        self._rxThread.join()  # wait for it to exit
+        if self._rxThread != threading.current_thread():
+            self._rxThread.join()  # wait for it to exit
 
     def __reader(self):
         """The reader thread that reads bytes from our stream"""

meshtastic/__main__.py

@@ -7,15 +7,27 @@ import sys
 from pubsub import pub
 import google.protobuf.json_format
 
+"""The command line arguments"""
+args = None
+
 
 def onReceive(packet):
     """Callback invoked when a packet arrives"""
     print(f"Received: {packet}")
 
 
-def onConnection(topic=pub.AUTO_TOPIC):
+def onConnection(interface, topic=pub.AUTO_TOPIC):
     """Callback invoked when we connect/disconnect from a radio"""
     print(f"Connection changed: {topic.getName()}")
+    global args
+    if topic.getName() == "meshtastic.connection.established" and args.info:
+        print(interface.myInfo)
+        print(interface.radioConfig)
+        interface.close()
+        print("Nodes in mesh:")
+        for n in interface.nodes.values():
+            asDict = google.protobuf.json_format.MessageToJson(n)
+            print(asDict)
 
 
 def onNode(node):
@@ -44,12 +56,16 @@ def main():
         help="Log device serial output to either 'stdout', 'none' or a filename to append to.  Defaults to stdout.",
         default="stdout")
 
+    parser.add_argument("--info", help="Read and display the radio config information",
+                        action="store_true")
+
     parser.add_argument("--debug", help="Show API library debug log messages",
                         action="store_true")
 
     parser.add_argument("--test", help="Run stress test against all connected Meshtastic devices",
                         action="store_true")
 
+    global args
     args = parser.parse_args()
     logging.basicConfig(level=logging.DEBUG if args.debug else logging.INFO)