diff --git a/src/hub/hub.py b/src/hub/hub.py new file mode 100644 index 0000000..8281607 --- /dev/null +++ b/src/hub/hub.py @@ -0,0 +1,22 @@ +""" +Creates hub for distributed IoT + +@author hornetfighter515 +@author Lachezar Todorov +""" + +from websocket_server import WebsocketServer + +def new_client(client, server): + print("Client has joined") + +def message_received(client, server, message): + print(message) + +int_server = WebsocketServer(host='127.0.0.1', port=6872) + + +ext_server = WebsocketServer(host='127.0.0.1', port=6873) +ext_server.set_fn_message_received(message_received) +ext_server.set_fn_new_client(new_client) +ext_server.run_forever()