wwww-wwww / phxsocket Goto Github PK

ERROR:root:phxsocket: Traceback (most recent call last):
  File "/home/work/.local/lib/python3.11/site-packages/phxsocket/client.py", line 109, in run
    loop.run_until_complete(
  File "/usr/lib/python3.11/asyncio/base_events.py", line 653, in run_until_complete
    return future.result()
           ^^^^^^^^^^^^^^^
  File "/home/work/.local/lib/python3.11/site-packages/phxsocket/client.py", line 97, in _run
    await asyncio.wait({listen, shutdown, broadcast},
          ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
TypeError: wait() got an unexpected keyword argument 'loop'

def connect_to_channel(socket: Client):

    print('OLITESTESTEST')
    channel = socket.channel("collection:boredapeyachtclub", {"payload": "{}"})
    resp = channel.join()

    print(f'OLI - Check channel is connected: {resp}')


def process_data(msg: Message):
    print(f'New data at {datetime.now()}: {msg}')

    if msg.event in [event.value for event in OpenseaStreamEvents]:

        data = msg.payload
        event_type = data['event_type']
        event_data = data['payload']
        event_data['event_type'] = event_type

        events.append(event_data)


socket = Client("wss://stream.openseabeta.com/socket/websocket", {'token': os.getenv('API_KEY_OPENSEA')})

socket.on_open = connect_to_channel
socket.on_message = process_data

print('Connecting...')
connection = socket.connect(blocking=False)