From d6653cc4a4f087f0f433bd7ddf24d3b8630981a2 Mon Sep 17 00:00:00 2001 From: Abhi Sharma Date: Sun, 3 Mar 2019 17:03:57 -0800 Subject: [PATCH 1/4] adding additional kontext server --- kws.py | 25 +++++++++++++++++++++++++ 1 file changed, 25 insertions(+) create mode 100644 kws.py diff --git a/kws.py b/kws.py new file mode 100644 index 0000000..98e0826 --- /dev/null +++ b/kws.py @@ -0,0 +1,25 @@ +from websocket_server import WebsocketServer + +# Called for every client connecting (after handshake) +def new_client(client, server): + print("New client connected and was given id %d" % client['id']) + # async reply back to the client + # server.send_message_to_all("Hey all, a new client has joined us") + + +# Called for every client disconnecting +def client_left(client, server): + print("Client(%d) disconnected" % client['id']) + + +# Called when a client sends a message +def message_received(client, server, message): + print("Client(%d) meta-data: %s" % (client['id'], message.metadata)) + print("Client(%d) content: %s" % (client['id'], message.content)) + +PORT=9500 +server = WebsocketServer(PORT) +server.set_fn_new_client(new_client) +server.set_fn_client_left(client_left) +server.set_fn_message_received(message_received) +server.run_forever() From 4b6a95eb2346d3480e3af69d8e3dd2500d6cc811 Mon Sep 17 00:00:00 2001 From: Abhi Sharma Date: Sun, 3 Mar 2019 19:05:48 -0800 Subject: [PATCH 2/4] added my own server --- kws.py | 3 +-- 1 file changed, 1 insertion(+), 2 deletions(-) diff --git a/kws.py b/kws.py index 98e0826..3d0da71 100644 --- a/kws.py +++ b/kws.py @@ -14,8 +14,7 @@ def client_left(client, server): # Called when a client sends a message def message_received(client, server, message): - print("Client(%d) meta-data: %s" % (client['id'], message.metadata)) - print("Client(%d) content: %s" % (client['id'], message.content)) + print("Client(%d) sent: %s" % (client['id'], message)) PORT=9500 server = WebsocketServer(PORT) From 29c8884a43f790c0e4c0dc2d3c3f0f4b1e9a34f1 Mon Sep 17 00:00:00 2001 From: Abhi Sharma Date: Mon, 4 Mar 2019 00:06:23 -0800 Subject: [PATCH 3/4] mv --- kws.py | 24 ------------------------ 1 file changed, 24 deletions(-) delete mode 100644 kws.py diff --git a/kws.py b/kws.py deleted file mode 100644 index 3d0da71..0000000 --- a/kws.py +++ /dev/null @@ -1,24 +0,0 @@ -from websocket_server import WebsocketServer - -# Called for every client connecting (after handshake) -def new_client(client, server): - print("New client connected and was given id %d" % client['id']) - # async reply back to the client - # server.send_message_to_all("Hey all, a new client has joined us") - - -# Called for every client disconnecting -def client_left(client, server): - print("Client(%d) disconnected" % client['id']) - - -# Called when a client sends a message -def message_received(client, server, message): - print("Client(%d) sent: %s" % (client['id'], message)) - -PORT=9500 -server = WebsocketServer(PORT) -server.set_fn_new_client(new_client) -server.set_fn_client_left(client_left) -server.set_fn_message_received(message_received) -server.run_forever() From 18af1a1116517230640b6f64dab54194adfa8aeb Mon Sep 17 00:00:00 2001 From: Abhi Sharma Date: Wed, 6 Mar 2019 21:43:56 -0800 Subject: [PATCH 4/4] bind to all IPv4 --- websocket_server/websocket_server.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/websocket_server/websocket_server.py b/websocket_server/websocket_server.py index 9d1af5c..f0d6fea 100644 --- a/websocket_server/websocket_server.py +++ b/websocket_server/websocket_server.py @@ -118,7 +118,7 @@ class WebsocketServer(ThreadingMixIn, TCPServer, API): clients = [] id_counter = 0 - def __init__(self, port, host='127.0.0.1', loglevel=logging.WARNING): + def __init__(self, port, host='0.0.0.0', loglevel=logging.WARNING): logger.setLevel(loglevel) TCPServer.__init__(self, (host, port), WebSocketHandler) self.port = self.socket.getsockname()[1]