Optional Client_Side Text Message Logging

Author: anmolbhat

meshtastic/__main__.py

@@ -66,6 +66,8 @@
 from meshtastic.protobuf import admin_pb2, channel_pb2, clientonly_pb2, config_pb2, portnums_pb2, mesh_pb2
 from meshtastic.version import get_active_version
 
+from meshtastic.message_store import MessageSettings, MessageStore, MessageLog, print_messages
+
 logger = logging.getLogger(__name__)
 
 # Map dotted preference paths to the protobuf enum that defines their flags.
@@ -600,6 +602,14 @@ def onConnected(interface):
                     onResponse=interface.getNode(args.dest, False, **getNode_kwargs).onAckNak,
                     portNum=portnums_pb2.PortNum.PRIVATE_APP if args.private else portnums_pb2.PortNum.TEXT_MESSAGE_APP
                 )
+
+                #Save Outbound Messages -- if save enabled
+                if mt_config.message_store:
+                    mt_config.message_store.log_sent(
+                        args.sendtext,
+                        destination_id=args.dest,
+                        channel=channelIndex,
+                    )
             else:
                 meshtastic.util.our_exit(
                     f"Warning: {channelIndex} is not a valid channel. Channel must not be DISABLED."
@@ -1642,6 +1652,18 @@ def common():
                 mt_config.logfile = logfile
 
             subscribe()
+
+            # (after the early arg checks, before any interface is constructed)
+            # Enable? StoreMessages? Call to get bool --> True (Save)
+            message_store = None
+            if handleMessageStoreArgs(args):
+                message_store = MessageStore(MessageLog())
+            mt_config.message_store = message_store   # so onConnected can reach it
+
+            #Display Messages
+            if handleShowMessagesArgs(args):
+                return
+
             if args.ble_scan:
                 logger.debug("BLE scan starting")
                 for x in BLEInterface.scan():
@@ -1806,6 +1828,70 @@ def common():
         # don't call exit, background threads might be running still
         # sys.exit(0)
 
+def handleMessageStoreArgs(args) -> bool:
+    """Resolve whether message logging is enabled for this run.
+
+    Reads --messages, updates the saved setting for on/off, and returns
+    the effective logging state. Does not attach hooks or exit.
+    """
+
+    args = mt_config.args
+    mode = args.messages
+
+    store = MessageSettings() 
+
+    # No flag: use the saved setting (defaults to off if missing/corrupt)
+    if mode is None:
+        return store.is_enabled()
+
+    if mode == "on":
+        store.set_enabled(True)     # persist
+        return True
+
+    if mode == "off":
+        store.set_enabled(False)    # persist
+        return False
+
+    if mode == "live":
+        # Log for this run only; saved setting is untouched
+        return True
+
+    if mode == "status":
+        saved = store.is_enabled()
+        print(f"Message logging is {'ON' if saved else 'OFF'}")
+        return saved
+
+    return False  # unreachable with argparse choices, but safe 
+
+def handleShowMessagesArgs(args) -> bool:
+    """Handle --show-messages. Returns True if it did, so the caller can stop
+    before any store is created or any connection is attempted."""
+
+    args = mt_config.args
+    parser = mt_config.parser
+
+    mode = getattr(args, "show_messages", None)
+    #
+    if mode is None:
+        return False
+
+    # Local-only command: refuse anything else that was actually set.
+    # Compare each arg to its parser default so unset flags don't count.
+    allowed = {"show_messages", "dest"} #Exclude dest -- which is set @BRDCST_ADDR 
+    others = [
+        "--" + name.replace("_", "-")
+        for name, value in vars(args).items()
+        if name not in allowed and value != parser.get_default(name)
+    ]
+    if others:
+        meshtastic.util.our_exit(
+            "Error: --show-messages can't be combined with: " + ", ".join(sorted(others)), 1
+        )
+
+    if mode == "all":
+        print_messages()
+    return True
+    
 
 def addConnectionArgs(parser: argparse.ArgumentParser) -> argparse.ArgumentParser:
     """Add connection specification arguments"""
@@ -2396,6 +2482,43 @@ def addRemoteAdminArgs(parser: argparse.ArgumentParser) -> argparse.ArgumentPars
 
     return parser
 
+
+def addMessageArgs(parser: argparse.ArgumentParser) -> argparse.ArgumentParser:
+    """Add message logging / history arguments."""
+    group = parser.add_argument_group(
+        "Messages",
+        "Persistent text-message logging (client-side JSONL). "
+    )
+
+    group.add_argument(
+        "--messages",
+        nargs="?",
+        const="status",
+        default=None,
+        choices=["on", "off", "status", "live"],
+        metavar="on|off|status|live",
+        help=(
+            "on/off: enable or disable message logging (saved) (default off). "
+            "status: show whether logging is on/off. "
+            "live: log messages for this run only, without changing the saved "
+            "setting. Combine with --listen or other commands."
+        )
+    )
+
+    group.add_argument(
+        "--show-messages",
+        nargs="?",
+        const="all",
+        default=None,
+        choices=["all"],
+        help=(
+            "Print stored messages. Currently supports: all."
+        )
+    )
+
+    return parser
+
+
 def initParser():
     """Initialize the command line argument parsing."""
     parser = mt_config.parser
@@ -2436,6 +2559,9 @@ def initParser():
     parser = addRemoteActionArgs(parser)
     parser = addRemoteAdminArgs(parser)
 
+    #Arguments for Message Parsing
+    parser = addMessageArgs(parser)
+
     # All the rest of the arguments
     group = parser.add_argument_group("Miscellaneous arguments")