tursom/blivedm
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

update

Browse Source
This commit is contained in:
tursom
2025-05-21 11:01:04 +08:00
parent 6dbcd6fba0
commit 3f54f14a3e
2 changed files with 3 additions and 9 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
main.py
View File

@@ -44,7 +44,8 @@ async def on_room_changed(new_room_ids):
TEST_ROOM_IDS = list(set(new_room_ids + room_from_config())) TEST_ROOM_IDS = list(set(new_room_ids + room_from_config()))
for removed in clients.keys() - TEST_ROOM_IDS: for removed in clients.keys() - TEST_ROOM_IDS:
await clients[removed].stop_and_close() print(f"room {removed} removed")
clients[removed].stop_and_close()
del clients[removed] del clients[removed]
if removed in log_files: if removed in log_files:

9
redis_util.py
View File

@@ -9,7 +9,7 @@ r: redis.Redis | None = None
on_room_changed: Callable[[list[int]], Awaitable[None]] | None = None on_room_changed: Callable[[list[int]], Awaitable[None]] | None = None
async def init(redis_conf: dict | None) -> None: def init(redis_conf: dict | None) -> None:
global r global r
if redis_conf is None: if redis_conf is None:
@@ -31,13 +31,6 @@ def get_room_list() -> list[int]:
return [int(room_id) for room_id in r.smembers(room_set_key)] return [int(room_id) for room_id in r.smembers(room_set_key)]
def _subscribe_redis():
loop = asyncio.new_event_loop()
asyncio.set_event_loop(loop)
loop.run_until_complete(_subscribe_redis_async())
loop.close()
async def _subscribe_redis_async(): async def _subscribe_redis_async():
p = r.pubsub() p = r.pubsub()
p.subscribe(f"__keyspace@0__:{room_set_key}") p.subscribe(f"__keyspace@0__:{room_set_key}")