Newer
Older
Mitchell Moore
committed
import signal
from flask import session
from flask_socketio import SocketIO, join_room
Ravi Tripathi
committed
from gevent import monkey
monkey.patch_all(subprocess=True)
config_name = os.getenv('FLASK_CONFIG')
app = create_app(config_name)
app.config['SECRET_KEY'] = 'vnkdjnfjknfl1232#'
socketio = SocketIO(app, message_queue='amqp://reggie:reggie@ohpc:5672/socketio')
#socketio = SocketIO(app)
#socketio = SocketIO(app, message_queue='amqp:///socketio')
Mitchell Moore
committed
@socketio.on('user connected')
def user_connected(json, methods=['GET', 'POST']):
username = json["user"]
room = str(session['uid'])
print(time.strftime("%m-%d-%Y_%H:%M:%S") + '\tUser ' + username + ' connected.')
print('\t\t\t|-----Room ID: ' + room)
Ravi Tripathi
committed
@socketio.on('join_room')
def on_room():
room = str(session['uid'])
join_room(room)
print('\t\t\t|-----Room ID: ' + room)
Mitchell Moore
committed
def request_account(json, methods=['GET', 'POST']):
print (time.strftime("%m-%d-%Y_%H:%M:%S") + '\tQueue request received: ' + str(json))
Ravi Tripathi
committed
sid = str(session['uid'])
#join_room(room)
print("Room: {}".format(sid))
#socketio.emit("creating account", room=sid)
# create_account(json['username'], json['fullname'], json['reason'])
#tasks.celery_create_account.delay(json['username'], json['fullname'], json['reason'], room, socketio, session=room)
Ravi Tripathi
committed
tasks.celery_create_account.delay(json['username'], json['fullname'], json['reason'], session=sid)
except Exception as e:
print(time.strftime("%m-%d-%Y_%H:%M:%S") + "\tError in account creation: ", e)
socketio.emit("Account creation failed", room)
socketio.run(app, host='0.0.0.0')