add detection of account creation

app/__init__.py

@@ -28,7 +28,7 @@ def create_app(config_name):
     @app.route('/', methods=['GET', 'POST']) # initial route to display the reg page
     def index():
         global return_url
-        username = "mmoo97"
+        username = "name_test"
 
         if "redir" in request.args and return_url == "": # check for redir arg in url
             return_url = request.args.get("redir") or "/pun/sys/dashboard"

app/templates/auth/SignUp.html

@@ -11,12 +11,15 @@
 
       socket.on( 'connect', function() {
         socket.emit( 'user connect', {
-          data: 'User Connected'
+          user: document.getElementById("username").innerText
         } )
 
        socket.on( 'creating account', function( msg ) {
            document.getElementById("error").innerText = "";
            displayloading();
+           socket.emit("validate creation", {
+               username: document.getElementById("username").innerText
+           })
       })
 
       socket.on( 'Account creation failed', function( msg ) {
@@ -24,8 +27,8 @@
       })
 
 
- 	socket.on( 'account created', function( msg ) {
-        document.getElementById("test").innerHTML = "Account Created!";
+ 	socket.on( 'Account created', function( msg ) {
+ 	    alert("Account creation successful!");
       })
 
 

run.py

@@ -17,14 +17,35 @@ def messageReceived(methods=['GET', 'POST']):
     print('message was received!!!')
 
 
+def check_dir(user, interval):
+    """
+    :param user: (string) username to check for in DB.
+    :param interval: (int) Frequency to check in seconds.
+    :return: (boolean) if account has been registered.
+    """
+    seconds = 0
+
+    while seconds < 600:
+        querystring = "_" + user + ".done"
+
+        for filename in os.listdir("flat_db/"):
+            if filename.endswith(querystring):
+                return True
+        time.sleep(interval)
+        seconds = seconds + interval
+
+    return False
+
+
 @socketio.on('user connect')
 def handle_my_custom_event(json, methods=['GET', 'POST']):
-    print('received my event: ' + str(json))
+    username = json["user"]
+    print('User ' + username + ' connected.')
 
 
 @socketio.on('user data')
-def confirm(json, methods=['GET', 'POST']):
-    print ('request received: ', str(json))
+def ingest_data(json, methods=['GET', 'POST']):
+    print ('Queue request received: ', str(json))
 
     try:
         fullname = json["fullname"]
@@ -44,12 +65,25 @@ def confirm(json, methods=['GET', 'POST']):
         file.write(reason)
 
         file.close()
+        print ('User ' + username + ' added to queue')
         socketio.emit("creating account")
+
     except Exception as e:
         print("Error in directory creation: ", e)
         socketio.emit("Account creation failed")
 
 
+@socketio.on("validate creation")
+def creation_confirmation(json, methods=['GET', 'POST']):
+    username = json["username"]
+
+    if check_dir(username, 10):
+        print ('Account successfully created for ' + username)
+        socketio.emit("Account created")
+    else:
+        socketio.emit("Account creation failed")
+
+
 if __name__ == '__main__':
    # app.run()
     socketio.run(app)