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

Closes #35 (closed)

models/client_model.py

                 client_file.write(json.dumps(self.clients, indent=2))
                 return True
         except OSError as error:
-            print(str(error))
+            logging.error(str(error))
             return False
 
     def secret(self, chars=36):

models/token_model.py

 from cryptography.fernet import Fernet, InvalidToken
 import datetime
+import logging
 import os
 import json
 
 
     def getKey(self):
         key = os.getenv(self.env_secret)
-        print(key)
+        logging.trace(key)
         if not key:
             key = Fernet.generate_key().decode()
             os.environ[self.env_secret] = key

tests/api_client_test.py

     ) as mock_getmtime, app.test_client() as app_test_client:
         response = app_test_client.get("/client/client-1")
         client_1 = response.json
-        print(client_1)
         client_1["subscription"] = "soar.client-1.#"
         response = app_test_client.put("/client/client-1", json=client_1)
-        print(response.data)
         assert response.status_code == 201
         assert "client_id" in response.json
         assert response.json["client_id"] == "client-1"

api.py

     app = Flask(__name__)
     api = Api(app)
     api_config = get_config()
-    logging.info(str(api_config))
+    logging.debug(str(api_config))
     CORS(app, resources=api_config["cors"])
 
     api.add_resource(ClientList, "/client")

logger.py

 
     # Set log level from env var or default if not set
     LOG_LEVEL = logging.getLevelName(os.getenv("LOG_LEVEL", "INFO"))
-    logging.basicConfig(level=LOG_LEVEL)
+    LOG_FORMAT = "%(asctime)s %(levelname)s %(name)s %(message)s"  
+    logging.basicConfig(
+        level=LOG_LEVEL, 
+        format=LOG_FORMAT,
+        datefmt='%Y-%m-%dT%H:%M:%S'
+    )
 
     # Downgrade log level for pika/watchdog which are noisy in DEBUG mode
     logging.getLogger("pika").setLevel(logging.ERROR)

rmq.py

     if connection is not None:
         channel = connection.channel()
     else:
-        print(
+        logging.error(
             "ERROR: Pika has been unable to connect to host '%s'. Is RabbitMQ running?"
             % host
         )
     while len(messages) < max_msgs:
         method_frame, header_frame, body = channel.basic_get(queue_name)
         if method_frame:
-            print(method_frame, header_frame, body)
             channel.basic_ack(method_frame.delivery_tag)
             try:
                 messages.append(json.loads(body.decode()))
             except json.decoder.JSONDecodeError:
                 messages.append(body.decode())
         else:
-            print("No message returned")
+            logging.debug("No message returned")
             break
     connection.close()
     logging.debug(f"Messages found: {len(messages)}")
-    logging.trace(json.dumps(messages))
+    if len(messages) > 0: 
+        logging.trace(json.dumps(messages))
     return messages
 
 
         channel.basic_consume(queue=from_queue, on_message_callback=forward_callback)
         channel.start_consuming()
     except pika.exceptions.AMQPChannelError as err:
-        print("Caught a channel error: {}, stopping...".format(err))
+        logging.error("Caught a channel error: {}, stopping...".format(err))
 
 
 def publish(queue_name, exchange_name):