Resolve "Add DEBUG log writes to soar_bus to show messages in transit"

Closes #35 (closed)

api.py

 from models.token_model import TokenModel
 
 
-logging.basicConfig(level=logging.INFO)
+logging.basicConfig(level=logging.DEBUG)
 logging.getLogger("pika").setLevel(logging.ERROR)
 token = TokenModel()
 token.setSecret()

rmq.py

 import json
+import logging
 import os
 
 import pika
 
 
 def write_to_queue(queue_name, msg):
+    logging.debug(f"Write to queue: {queue_name}")
     # write a single message to a queue
     connection, channel = pika_connect(host=host)
     setup_queue(channel=channel, queue_name=queue_name)
 
 
 def read_from_queue(queue_name, max_msgs):
+    logging.debug(f"Read from queue: {queue_name} (max_msgs: {max_msgs})")
     # get messages off of a queue until the queue is empty or max_msgs is hit
     connection, channel = pika_connect(host=host)
 
         else:
             print("No message returned")
             break
-
     connection.close()
+    logging.debug(f"Messages found: {len(messages)}")
     return messages
 
 
     setup_queue(channel=channel, queue_name=queue_name)
 
     def broadcast_callback(ch, method, properties, body):
+        logging.debug(f"Broadcast from queue: {queue_name} to exchange {exchange_name}")    
         deliver_to_exchange(channel=ch, body=body, exchange_name=exchange_name)
         ch.basic_ack(delivery_tag=method.delivery_tag)
 
     setup_queue(channel=channel, queue_name=to_queue)
 
     def forward_callback(ch, method, properties, body):
+        logging.debug(f"Forward from queue: {from_queue} to queue: {to_queue}")    
         channel.basic_publish(
             exchange="",
             routing_key=to_queue,
     def publish_callback(ch, method, properties, body):
         message = json.loads(body.decode())
         topic = message["topic"]
+        logging.debug(f"Publish from queue: {queue_name} to exchange {exchange_name} with topic {topic}")
         deliver_to_exchange(
             channel=ch, body=body, exchange_name=exchange_name, topic=topic
         )
 
 
 def subscribe(queue_name, exchange_name, topic=None):
+    logging.debug(f"Subscribe queue: {queue_name} to {exchange} with topic {topic}")
     # setup bindings between queue and exchange,
     # exchange_type is either 'fanout' or 'topic' based on if the topic arg is passed
     connection, channel = pika_connect(host=host)
 
 
 def listen(queue_name, callback):
+    logging.debug(f"Listen to queue: {queue_name}") 
     # subscribe client to a queue, using the callback arg
     _, channel = pika_connect(host=host)