From 8c782c14965cffa24ecda262ce53f8ee30f90ed2 Mon Sep 17 00:00:00 2001
From: JarbasAI <33701864+JarbasAl@users.noreply.github.com>
Date: Sat, 11 Sep 2021 03:12:55 -1000
Subject: [PATCH] add new util script - bus monitor

allow to watch what's traveling on the messagebus real time
---
 .../rootfs-overlay/usr/bin/bus-monitor        | 33 +++++++++++++++++++
 1 file changed, 33 insertions(+)
 create mode 100644 buildroot-external/rootfs-overlay/usr/bin/bus-monitor

diff --git a/buildroot-external/rootfs-overlay/usr/bin/bus-monitor b/buildroot-external/rootfs-overlay/usr/bin/bus-monitor
new file mode 100644
index 00000000..5a867586
--- /dev/null
+++ b/buildroot-external/rootfs-overlay/usr/bin/bus-monitor
@@ -0,0 +1,33 @@
+#!/usr/bin/env python3
+import traceback
+from time import sleep
+from mycroft.util.log import LOG
+from mycroft.util.time import now_local
+from mycroft.messagebus import MessageBusClient
+
+
+def on_message(message):
+    dt = str(now_local())[:19]
+    print(f"{dt} >> {message}")
+
+
+def main():
+    sleep(0.5)
+    # Connect to the default websocket used by mycroft-core
+    # TODO arg parse
+    client = MessageBusClient()
+    client.on("message", on_message)
+    client.run_forever()
+    LOG.info('Client stopped.')
+
+
+if __name__ == '__main__':
+    # Run loop trying to reconnect if there are any issues starting
+    # the websocket
+    while True:
+        try:
+            main()
+        except KeyboardInterrupt:
+            break
+        except:
+            traceback.print_exc()