import asyncio, websockets, logging, os, binascii

logging.basicConfig()

SERVER_IP = '192.168.1.2';
SERVER_PORT = 4441

class WebSocketsServer:

        def __init__(self, ip, port):
                self.clients = {}
                self.ip = ip
                self.port = port

        async def start(self):
                await websockets.serve(self.listen, self.ip, self.port)

        # end __init__

        async def listen(self, websocket, path):
                id = self.generate_id(16)
                self.clients[id] = websocket

                await self.handle_client(id, websocket)

        # end listen

        async def handle_client(self, id, websocket):
                print(id + ' connected')

                while True:
                        try:
                                data = await websocket.recv()
                                print(id + ': ' + data)

                        except websockets.exceptions.WebSocketException:
                                print(id + ' disconnected')
                                await websocket.close()
                                break

        # end handle_client

        def generate_id(self, len):
                id = None

                while id is None or id in list(self.clients):
                        id = binascii.b2a_hex(os.urandom(int(len / 2))).decode(encoding='utf-8')

                return id

        # end generate_id

server = WebSocketsServer(SERVER_IP, SERVER_PORT)

asyncio.get_event_loop().run_until_complete(server.start());
asyncio.get_event_loop().run_forever()