update
This commit is contained in:
4
main.py
4
main.py
@@ -45,7 +45,7 @@ async def on_room_changed(new_room_ids):
|
|||||||
|
|
||||||
for removed in clients.keys() - TEST_ROOM_IDS:
|
for removed in clients.keys() - TEST_ROOM_IDS:
|
||||||
print(f"room {removed} removed")
|
print(f"room {removed} removed")
|
||||||
clients[removed].stop_and_close()
|
await clients[removed].stop_and_close()
|
||||||
del clients[removed]
|
del clients[removed]
|
||||||
|
|
||||||
if removed in log_files:
|
if removed in log_files:
|
||||||
@@ -70,7 +70,7 @@ async def main():
|
|||||||
|
|
||||||
flush_files()
|
flush_files()
|
||||||
|
|
||||||
await redis.init(conf.get("redis", None))
|
redis.init(conf.get("redis", None))
|
||||||
redis.on_room_changed = on_room_changed
|
redis.on_room_changed = on_room_changed
|
||||||
TEST_ROOM_IDS = list(set(TEST_ROOM_IDS + redis.get_room_list()))
|
TEST_ROOM_IDS = list(set(TEST_ROOM_IDS + redis.get_room_list()))
|
||||||
|
|
||||||
|
|||||||
Reference in New Issue
Block a user