From 7ad12e0ff844c9ffcd5679887b655c309a788bed Mon Sep 17 00:00:00 2001
From: Krish Moodbidri <krish94@uab.edu>
Date: Fri, 10 Apr 2020 10:44:31 -0500
Subject: [PATCH] Send user data from flask to clery as a json object
---
run.py | 10 +++++++++-
tasks.py | 7 +++++--
2 files changed, 14 insertions(+), 3 deletions(-)
diff --git a/run.py b/run.py
index 9ed918f..c32c1b8 100644
--- a/run.py
+++ b/run.py
@@ -18,6 +18,14 @@ app = create_app(config_name)
app.config['SECRET_KEY'] = vars.key
socketio = SocketIO(app, message_queue= vars.message_queue)
+
+user_data = {
+ 'username' : username
+ 'fullname' : fullname
+ 'reason' : reason
+ 'session' : room
+}
+
@socketio.on('connect')
def socket_connect():
pass
@@ -39,7 +47,7 @@ def request_account(json, methods=['GET', 'POST']):
room = str(session['uid'])
print("Room: {}".format(room))
try:
- tasks.celery_create_account.delay(json['username'], json['fullname'], json['reason'], session=room)
+ tasks.celery_create_account.delay(user_data)
except Exception as e:
print(time.strftime("%m-%d-%Y_%H:%M:%S") + "\tError in account creation: ", e)
socketio.emit("Account creation failed", room)
diff --git a/tasks.py b/tasks.py
index 7deec3a..d995d41 100644
--- a/tasks.py
+++ b/tasks.py
@@ -19,8 +19,11 @@ def send_msg(event, room):
@celery.task
-def celery_create_account(username, fullname, reason, session):
- room = session
+def celery_create_account(user_data):
+ username = user_data.username
+ fullname = user_data.fullname
+ reason = user_data.reason
+ room = user_data.session
print(time.strftime("%m-%d-%Y_%H:%M:%S") + '\tUser ' + username + ' added to queue')
send_msg('creating account', room)
print(username)
--
GitLab