Using realtime.listen() in a separate thread

[lschaupp]

Hello,

Is it possible to use the realtime.listen() function in a separate thread?
All my trials have failed so far causing following exception:

raise RuntimeError('There is no current event loop in thread %r.'

at the line: loop = asyncio.get_event_loop() # TODO: replace with get_running_loop in connection.py

Cheers

[albertpurnama]

I'm interested in working on this. But I'm not sure where to start, I'm thinking of exposing the internal functions like _connect(), etc for use somehow.

I might be very off here, is there someone that I can talk to about the high level implementation on this?

Maybe @silentworks have some insights?

[albertpurnama]

For my case, running realtime with existing web server (FastAPI) crashes because there's already event loop running managed by FastAPI.

RuntimeError: this event loop is already running.

The workaround for me is to use the _connect() and _listen() and _join directly.

async def start():
    URL = f'wss://{os.getenv("SUPABASE_ID", "")}.supabase.co/realtime/v1/websocket?apikey={os.getenv("SUPABASE_SERVICE_ROLE_KEY", "")}&vsn=1.0.0'

    s = Socket(URL)
    # s.connect()
    await s._connect()

    channel_1 = cast(Channel, s.set_channel("realtime:storage:objects"))
    
    # channel_1.join().on("UPDATE", reindex)
    await asyncio.create_task(channel_1._join())
    channel_1.on("UPDATE", reindex)

    #s.listen()
    asyncio.create_task(s._listen())
    asyncio.create_task(s._keep_alive())

I wonder what the # TODO: replace with get_running_loop is supposed to mean 🤔

I tried replacing get_event_loop to get_running_loop but it doesn't work for my case. Probably skill issues. Guidance appreciated!

cc @J0

[regregoff]

Hello,

Is it possible to use the realtime.listen() function in a separate thread? All my trials have failed so far causing following exception:

raise RuntimeError('There is no current event loop in thread %r.'

at the line: loop = asyncio.get_event_loop() # TODO: replace with get_running_loop in connection.py

Cheers

To solve this problem, you need to create and run an event loop inside the function, which will be executed in a separate thread.

def socket_listen()
    loop = asyncio.new_event_loop()
    asyncio.set_event_loop(loop)
    s = Socket(URL)
    s.connect()
    channel_1 = s.set_channel("realtime:*")
    s.listen()