diff --git a/tasks.py b/tasks.py index 1e8a4152e898a86fadb69b2413cb8dec681fd462..d73e3a02fb954c76280bb90e82ca65d5a344b969 100644 --- a/tasks.py +++ b/tasks.py @@ -3,6 +3,7 @@ import time from flask_socketio import SocketIO import subprocess import vars +import rc_util from gevent import monkey monkey.patch_all(subprocess=True) @@ -19,12 +20,17 @@ def send_msg(event, room): @celery.task -def celery_create_account(username, fullname, reason, session): +def celery_create_account(json, session): room = session + username= json['username'] + email= json['email'] + fullname= json['fullname'] + reason= json['reason'] print(time.strftime("%m-%d-%Y_%H:%M:%S") + '\tUser ' + username + ' added to queue') send_msg('creating account', room) print(username) - subprocess.call(["/opt/rabbitmq_agents/create_account.py", username, email, fullname, reason]) - print(username + email + fullname + reason) + #subprocess.call(["/opt/rabbitmq_agents/create_account.py", username, email, fullname, reason]) + rc_util.add_account(username, email, fullname, reason) + rc_util.consume(username) print(time.strftime("%m-%d-%Y_%H:%M:%S") + '\tAccount successfully created for ' + username) send_msg('account ready', room)