how to use and configure python websockets module and stuff

class Server():
    def __init__(self):
        self.BUFSIZ = 4096
        self.loop = asyncio.get_event_loop()
        self.logger = _create_logger()
        self.addresses_in_game = {}
        self.addresses = {}
        self.last_movement_packet = {}
        self.email_for_address = {}
        self.listen()

    def listen(self, host='0.0.0.0', port=port):
        self.logger.info("listening on {}:{}".format(host, port))
        ws_server = websockets.serve(self.handle_connection, host, port)

        self.loop.run_until_complete(ws_server)
        self._wake_up_task = asyncio.ensure_future(_wake_up())

        try:
            self.loop.run_forever()
        except KeyboardInterrupt:
            self.logger.debug('caught keyboard interrupt')
            self.logger.info("exiting")
            self._wake_up_task.cancel()
            try:
                self.loop.run_until_complete(self._wake_up_task)
            except asyncio.CancelledError:
                self.loop.close()
    async def handle_connection(self,client):
        """Sets up handling for incoming clients."""
        print("%s:%s has connected." % client.remote_address)
        self.addresses[client] = client.remote_address
        await self.handle_client(client,client.remote_address)

    # Takes client socket as argument.
    async def handle_client(self, client, client_address):
        """Handles a single client connection."""
        while True:
            msg = await client.recv()
            if msg != b'':
                await self.run_function(client, msg)
            else:
                await client.close()
                break

    async def broadcast(self, msg, id_):  # prefix is for name identification.
        """Broadcasts a message to all the clients."""

        for client in self.player_clients_in_game[str(id_)]:
            await client.send(msg.encode())

class Server():
    def __init__(self):
        self.BUFSIZ = 4096
        self.loop = asyncio.get_event_loop()
        self.logger = _create_logger()
        self.addresses_in_game = {}
        self.addresses = {}
        self.last_movement_packet = {}
        self.email_for_address = {}
        self.listen()

    def listen(self, host='0.0.0.0', port=port):
        self.logger.info("listening on {}:{}".format(host, port))
        ws_server = websockets.serve(self.handle_connection, host, port)

        self.loop.run_until_complete(ws_server)
        self._wake_up_task = asyncio.ensure_future(_wake_up())

        try:
            self.loop.run_forever()
        except KeyboardInterrupt:
            self.logger.debug('caught keyboard interrupt')
            self.logger.info("exiting")
            self._wake_up_task.cancel()
            try:
                self.loop.run_until_complete(self._wake_up_task)
            except asyncio.CancelledError:
                self.loop.close()
    async def handle_connection(self,client):
        """Sets up handling for incoming clients."""
        print("%s:%s has connected." % client.remote_address)
        self.addresses[client] = client.remote_address
        await self.handle_client(client,client.remote_address)

    # Takes client socket as argument.
    async def handle_client(self, client, client_address):
        """Handles a single client connection."""
        while True:
            msg = await client.recv()
            if msg != b'':
                await self.run_function(client, msg)
            else:
                await client.close()
                break

    async def broadcast(self, msg, id_):  # prefix is for name identification.
        """Broadcasts a message to all the clients."""

        for client in self.player_clients_in_game[str(id_)]:
            await client.send(msg.encode())

async def _wake_up():
    while True:
        await asyncio.sleep(1)

async def _wake_up():
    while True:
        await asyncio.sleep(1)

# server.py
import asyncio
import websockets

async def echo(websocket, path):
    async for message in websocket:
        print(f"Received message: {message}")

start_server = websockets.serve(echo, "localhost")

asyncio.get_event_loop().run_until_complete(start_server)
asyncio.get_event_loop().run_forever()

# server.py
import asyncio
import websockets

async def echo(websocket, path):
    async for message in websocket:
        print(f"Received message: {message}")

start_server = websockets.serve(echo, "localhost")

asyncio.get_event_loop().run_until_complete(start_server)
asyncio.get_event_loop().run_forever()

import os
import asyncio
from websockets.server import serve

async def echo(websocket):
    async for message in websocket:
        await websocket.send(message)

async def main():
    port = os.getenv("PORT", "3000")
    async with serve(echo, "0.0.0.0", port):
        print(f"running websocket server on port {port}")
        await asyncio.Future()  # run forever

asyncio.run(main())

import os
import asyncio
from websockets.server import serve

async def echo(websocket):
    async for message in websocket:
        await websocket.send(message)

async def main():
    port = os.getenv("PORT", "3000")
    async with serve(echo, "0.0.0.0", port):
        print(f"running websocket server on port {port}")
        await asyncio.Future()  # run forever

asyncio.run(main())

async def send_data():
    uri = "wss://test-production-6637.up.railway.app/"
    async with websockets.connect(uri) as websocket:
        sensor_data = {
            "temperature": random.uniform(20.0, 25.0),
            "humidity": random.uniform(30.0, 40.0),
        }
        await websocket.send(json.dumps(sensor_data))

asyncio.get_event_loop().run_until_complete(send_data())

async def send_data():
    uri = "wss://test-production-6637.up.railway.app/"
    async with websockets.connect(uri) as websocket:
        sensor_data = {
            "temperature": random.uniform(20.0, 25.0),
            "humidity": random.uniform(30.0, 40.0),
        }
        await websocket.send(json.dumps(sensor_data))

asyncio.get_event_loop().run_until_complete(send_data())

connection handler failed
Traceback (most recent call last):
File "/usr/local/lib/python3.10/site-packages/websockets/legacy/server.py", line 240, in handler
await self.ws_handler(self)
File "/app/test.py", line 8, in echo
await websocket.send(message)
File "/usr/local/lib/python3.10/site-packages/websockets/legacy/protocol.py", line 635, in send
await self.ensure_open()
File "/usr/local/lib/python3.10/site-packages/websockets/legacy/protocol.py", line 944, in ensure_open
raise self.connection_closed_exc()
websockets.exceptions.ConnectionClosedOK: received 1000 (OK); then sent 1000 (OK)

connection handler failed
Traceback (most recent call last):
File "/usr/local/lib/python3.10/site-packages/websockets/legacy/server.py", line 240, in handler
await self.ws_handler(self)
File "/app/test.py", line 8, in echo
await websocket.send(message)
File "/usr/local/lib/python3.10/site-packages/websockets/legacy/protocol.py", line 635, in send
await self.ensure_open()
File "/usr/local/lib/python3.10/site-packages/websockets/legacy/protocol.py", line 944, in ensure_open
raise self.connection_closed_exc()
websockets.exceptions.ConnectionClosedOK: received 1000 (OK); then sent 1000 (OK)