Added tornado websocket

Author: jscriptcoder

package.json

@@ -7,7 +7,7 @@
     "axios-client": "babel-node src/clients/http/axios_client.js",
     "fetch-client": "babel-node src/clients/http/fetch_client.js",
     "superagent-client": "babel-node src/clients/http/superagent_client.js",
-    "socketio-client": "babel-node src/clients/ws/socketio_client.js",
+    "socketio-client": "babel-node src/clients/socketio/socketio_client.js",
     "websocket-client": "babel-node src/clients/ws/websocket_client.js",
     "ws-client": "babel-node src/clients/ws/ws_client.js",
     "stomp-client": "babel-node src/clients/ws/stomp_client.js"

requirements.txt

@@ -1,5 +1,6 @@
 Flask==1.1.2
 Flask-SocketIO==4.3.1
+gevent-websocket==0.10.1
 eventlet==0.27.0
 websockets==8.1
 fastapi==0.61.1

src/clients/ws/socketio_client.js renamed to src/clients/socketio/socketio_client.js

@@ -41,7 +41,7 @@ async function runTest() {
         socket.close()
 
     } catch(err) {
-        console.error('Error connecting')
+        console.error('Error connecting:', err)
     }
 }
 

src/clients/ws/websocket_client.js

@@ -46,7 +46,7 @@ async function runTest() {
         connection.close(1000, 'Done testing')
 
     } catch(err) {
-        console.error('Error connecting')
+        console.error('Error connecting:', err)
     }
 }
 

src/clients/ws/ws_client.js

@@ -42,7 +42,7 @@ async function runTest() {
         ws.terminate()
 
     } catch(err) {
-        console.error('Error connecting')
+        console.error('Error connecting:', err)
     }
 }
 

src/servers/ws/flask-socketio_server.py renamed to src/servers/socketio/flask-socketio_server.py

@@ -0,0 +1,30 @@
+#!/usr/bin/env python
+
+import json
+from tornado.web import Application
+from tornado.ioloop import IOLoop
+from tornado.websocket import WebSocketHandler
+from tornado.httpserver import HTTPServer
+from src.servers.config import host, port
+from src.servers.utils import random_greeting
+
+class GreetingHandler(WebSocketHandler):
+    def on_message(self, message):
+        data = json.loads(message)
+        greeting = random_greeting(data['name'])
+        self.write_message({ 'greeting': greeting })
+    
+def make_app():
+    urls = [('/greeting', GreetingHandler)]
+    return Application(urls)
+
+def run_test():
+    print('Server starting at ' + 'ws://{}:{}'.format(host, port))
+
+    app = make_app()
+    http_server = HTTPServer(app)
+    http_server.listen(port, host)
+    IOLoop.current().start()
+
+if __name__ == '__main__':
+    run_test()