Add rough Todo comments for RabbitMQ implementation

run.py

@@ -18,6 +18,8 @@ def messageReceived(methods=['GET', 'POST']):
 
 
 def check_dir(user, interval):
+    # Todo: Make this mothod in a consumer
+
     """
     :param user: (string) username to check for in DB.
     :param interval: (int) Frequency to check in seconds.
@@ -47,34 +49,40 @@ def handle_my_custom_event(json, methods=['GET', 'POST']):
 def ingest_data(json, methods=['GET', 'POST']):
     print (time.strftime("%m-%d-%Y_%H:%M:%S") + '\tQueue request received: ' + str(json))
 
-    try:
-        fullname = json["fullname"]
-        reason = json["reason"]
-        username = json["username"]
-
-        time_stamp = time.strftime("%m-%d-%Y_%H:%M:%S")
-        directory = "flat_db/"
-        complete_file_name = os.path.join(directory, time_stamp + "_" + username + ".txt")
-
-        if not os.path.exists(directory):
-            os.makedirs(directory)
-
-        file = open(complete_file_name, "w")  # create time stamped file to be queued
-
-        file.write(fullname + "\n")
-        file.write(reason)
-
-        file.close()
-        print (time.strftime("%m-%d-%Y_%H:%M:%S") + '\tUser ' + username + ' added to queue')
-        socketio.emit("creating account")
-
-    except Exception as e:
-        print(time.strftime("%m-%d-%Y_%H:%M:%S") + "\tError in directory creation: ", e)
-        socketio.emit("Account creation failed")
+    # Todo: Insert rabbitMQ implementation here
+    # Todo: Make this part of the method a producer
+    # Todo: Make the remaining protion of this method in a RabbitMQ consumer
+
+    # try:
+    #     fullname = json["fullname"]
+    #     reason = json["reason"]
+    #     username = json["username"]
+    #
+    #     time_stamp = time.strftime("%m-%d-%Y_%H:%M:%S")
+    #     directory = "flat_db/"
+    #     complete_file_name = os.path.join(directory, time_stamp + "_" + username + ".txt")
+    #
+    #     if not os.path.exists(directory):
+    #         os.makedirs(directory)
+    #
+    #     file = open(complete_file_name, "w")  # create time stamped file to be queued
+    #
+    #     file.write(fullname + "\n")
+    #     file.write(reason)
+    #
+    #     file.close()
+    #     print (time.strftime("%m-%d-%Y_%H:%M:%S") + '\tUser ' + username + ' added to queue')
+    #     socketio.emit("creating account")
+    #
+    # except Exception as e:
+    #     print(time.strftime("%m-%d-%Y_%H:%M:%S") + "\tError in directory creation: ", e)
+    #     socketio.emit("Account creation failed")
 
 
 @socketio.on("validate creation")
 def creation_confirmation(json, methods=['GET', 'POST']):
+    # Todo: Make this mthod in a RabbitMQ consumer
+
     username = json["username"]
 
     if check_dir(username, 10):