From f689ce549689b3192ce1f7510804495acfd7869d Mon Sep 17 00:00:00 2001 From: Christopher Baklid Date: Tue, 22 May 2018 22:12:43 +0200 Subject: adds webapp and docker-compose for more proof of concept --- webapp/webapp.py | 39 +++++++++++++++++++++++++++++++++++++++ 1 file changed, 39 insertions(+) create mode 100644 webapp/webapp.py (limited to 'webapp/webapp.py') diff --git a/webapp/webapp.py b/webapp/webapp.py new file mode 100644 index 0000000..676fc27 --- /dev/null +++ b/webapp/webapp.py @@ -0,0 +1,39 @@ +import traceback + +from rmq import send as rmq_send +from flask import Flask +from flask import render_template +from flask_sockets import Sockets + +app = Flask(__name__) +sockets = Sockets(app) + +@app.route('/') +def index(): + return render_template('index.html') + +@sockets.route('/ws') +def websocket_route(ws): + try: + while not ws.closed: + message = ws.receive() + + if not message: + continue + print(f"received '{message}'") + + rmq_send(message) + + except: + print(traceback.format_exec()) + + finally: + if not ws.closed: + ws.close() + +if __name__ == '__main__': + #app.run(host='0.0.0.0', port=5000, debug=True) + from gevent import pywsgi + from geventwebsocket.handler import WebSocketHandler + server = pywsgi.WSGIServer(('0.0.0.0', 5000), app, handler_class=WebSocketHandler) + server.serve_forever() -- cgit v1.2.3