Added functions to broker_functions.py and organized comments

Author: Juliana Mashon

api_functions.py

@@ -42,7 +42,7 @@ def set_info(self, endpoint, field, value, id=None):
         self.api_connect.patch(endpoint, id, new_value)
         return self.api_connect.get(endpoint, id)
 
-    def env(self, id=None, field=None, new_val=None):
+    def env(self, id=None, field=None, new_val=None): # TODO: why are there '?'
         if id is None:
             data = self.api_connect.get('farmware_envs', id=None)
             print(data) # ?
@@ -86,8 +86,8 @@ def garden_size(self):
                     f'\ty length = {length_y:.2f}\n'
                     f'\tarea = {area:.2f}')
 
-    def group(self, id): ## MAKE ID OPTIONAL RETURN FULL TREE W/O ID
+    def group(self, id): # TODO: make ID optional return full tree w/o ID
         return self.get_info('point_groups', id)
 
-    def curve(self, id): ## MAKE ID OPTIONAL RETURN FULL TREE W/O ID
+    def curve(self, id): # TODO: make ID optional return full tree w/o ID
         return self.get_info('curves', id)

broker_connect.py

@@ -62,7 +62,7 @@ def on_message(self, _client, _userdata, msg):
         new_message = json.loads(msg.payload)
         self.last_message = new_message
 
-    def listen(self, duration, channel='#'):
+    def listen(self, duration, channel):
         """Listen to messages via message broker."""
 
         if self.client is None:
@@ -79,3 +79,33 @@ def listen(self, duration, channel='#'):
 
         self.client.loop_stop()
         self.client.disconnect()
+
+    ## FUNCTIONS -- HIDDEN
+
+    def hidden_on_connect(self, _client, _userdata, _flags, _rc):
+        # Subscribe to all channels
+        self.client.subscribe(f"bot/{self.token['token']['unencoded']['bot']}/#")
+
+    def hidden_on_message(self, _client, _userdata, msg):
+        # print channel
+        print('-' * 100)
+        print(f'{msg.topic} ({datetime.now().strftime("%Y-%m-%d %H:%M:%S")})\n')
+        # print message
+        print(json.dumps(json.loads(msg.payload), indent=4))
+
+    def hidden_listen(self):
+        if self.client is None:
+            self.connect()
+
+        self.client.on_connect = self.hidden_on_connect
+        self.client.on_message = self.hidden_on_message
+
+        # Start loop in a separate thread
+        self.client.loop_start()
+
+        # Sleep for five seconds to listen for messages
+        time.sleep(60)
+
+        # Stop loop and disconnect after five seconds
+        self.client.loop_stop()
+        self.client.disconnect()