add option to disable json output

Author: gabrielburnworth

farmbot_sidecar_starter_pack/functions/broker.py

@@ -79,7 +79,7 @@ def publish(self, message):
         if rpc["args"]["label"] == "":
             rpc["args"]["label"] = uuid.uuid4().hex if not self.state.test_env else "test"
 
-        self.state.print_status(description="Publishing to 'from_clients':")
+        self.state.print_status(description="Publishing to 'from_clients'")
         self.state.print_status(endpoint_json=rpc, update_only=True)
         if self.state.dry_run:
             self.state.print_status(description="Sending disabled, message not sent.", update_only=True)
@@ -114,7 +114,7 @@ def on_message(_client, _userdata, msg):
             timestamp = datetime.now().strftime("%Y-%m-%d %H:%M:%S")
             self.state.print_status(
                 endpoint_json=json.loads(msg.payload),
-                description=f"TOPIC: {msg.topic} ({timestamp})\n")
+                description=f"New message from {msg.topic} ({timestamp})")
 
         self.client.on_message = on_message
 
@@ -184,7 +184,6 @@ def listen(self, channel, duration=None, publish_payload=None):
                     self.state.last_messages[channel] = None
                     continue
                 seconds = (datetime.now() - start_time).seconds
-                self.state.print_status(description="", update_only=True)
                 self.state.print_status(
                     description=f"Message received after {seconds} seconds",
                     update_only=True)

farmbot_sidecar_starter_pack/state.py

@@ -35,6 +35,7 @@ def __init__(self):
         self.last_messages = {}
         self.last_published = {}
         self.verbosity = 2
+        self.json_printing = True
         self.timeout = {
             "api": 15,
             "listen": 15,
@@ -64,7 +65,7 @@ def print_status(self, endpoint_json=None, description=None, update_only=False,
                 print()
             if description is not None:
                 print(indent + description, end=end, flush=(end == ""))
-            if endpoint_json:
+            if endpoint_json is not None and self.json_printing:
                 json_str = json.dumps(endpoint_json, indent=4)
                 indented_str = indent + json_str.replace("\n", "\n" + indent)
                 print(indented_str)