ebraminio / aiosseclient Goto Github PK

I use this in https://github.com/dpriskorn/asseeibot and would like to fetch it from PIP if possible.

I am operating against the Firebase Realtime Database.

I have the following code

import threading
from time import sleep

url = "https://databaseurl/messages.json?auth=idtoken"

async def message_reader():
    async for event in aiosseclient(url):
        print(event.event)
        print(event)

message_reader_thread = threading.Thread(target=asyncio.run, args=(message_reader(),))
message_reader_thread.start()

while True:
    print("Still reading messages")
    sleep(30)

This code works, but breaks in two cases that I can't understand how to handle. First is when the idtoken is bad and response gets a 401 back. The While loop still runs, but there is no error or way to exit the for loop. The second is when idtoken expires (they only last an hour) and an event "auth_revoked" is received. Again, there is no way to observe the error, and the for loop keeps going because it is still getting "keep-alive" events, even though it's not receiving data anymore.

I need some way to have the script fail and exit on 401 and I need a way to somehow refresh/restart it with a new idtoken periodically (hourly in this case).

Thabks a lot for writing and sharing this ❤
I just build a small script/bot using this and mediawikiapi.
I have a suggestion to expand he readme with a filtering example, woukd that be accepted?

The library works for me, but when receiving very large messages/packets an error is generated: "Chunk too big"

I would like to have an option to just ignore these very large chunks, or if it were possible to get them normally without any errors.

There is a fork with that, upstream it?