From 6dbcd6fba021149857aaa60278104e474dcd309f Mon Sep 17 00:00:00 2001
From: tursom <tursom@foxmail.com>
Date: Wed, 21 May 2025 10:57:51 +0800
Subject: [PATCH] update

---
 main.py       | 2 +-
 redis_util.py | 5 ++---
 2 files changed, 3 insertions(+), 4 deletions(-)

diff --git a/main.py b/main.py
index 46ba22d..b2dcd61 100644
--- a/main.py
+++ b/main.py
@@ -69,7 +69,7 @@ async def main():
 
     flush_files()
 
-    redis.init(conf.get("redis", None))
+    await redis.init(conf.get("redis", None))
     redis.on_room_changed = on_room_changed
     TEST_ROOM_IDS = list(set(TEST_ROOM_IDS + redis.get_room_list()))
 
diff --git a/redis_util.py b/redis_util.py
index be4fce8..d8602c6 100644
--- a/redis_util.py
+++ b/redis_util.py
@@ -9,7 +9,7 @@ r: redis.Redis | None = None
 on_room_changed: Callable[[list[int]], Awaitable[None]] | None = None
 
 
-def init(redis_conf: dict | None):
+async def init(redis_conf: dict | None) -> None:
     global r
 
     if redis_conf is None:
@@ -21,8 +21,7 @@ def init(redis_conf: dict | None):
         db=redis_conf.get("port", 0),
     )
 
-    # run subscribe_redis on new thread
-    threading.Thread(target=_subscribe_redis, daemon=True).start()
+    asyncio.create_task(_subscribe_redis_async())
 
 
 def get_room_list() -> list[int]: