diff --git a/starbot/core/bot.py b/starbot/core/bot.py index b78ea75..b9c2bbd 100644 --- a/starbot/core/bot.py +++ b/starbot/core/bot.py @@ -117,13 +117,14 @@ class StarBot: await asyncio.sleep(0.2) except LiveException as ex: logger.error(ex.msg) - try: - wait_time = config.get("WAIT_FOR_ALL_CONNECTION_TIMEOUT") - if wait_time == 0: - wait_time = len(self.__datasource.get_up_list()) // 5 * 2 - await asyncio.wait_for(self.__datasource.wait_for_connects(), wait_time) - except asyncio.exceptions.TimeoutError: - logger.warning("等待连接所有直播间超时, 请检查是否存在未连接成功的直播间") + if len(self.__datasource.get_up_list()) > 0: + try: + wait_time = config.get("WAIT_FOR_ALL_CONNECTION_TIMEOUT") + if wait_time == 0: + wait_time = (len(self.__datasource.get_up_list()) + 5) // 5 * 2 + await asyncio.wait_for(self.__datasource.wait_for_connects(), wait_time) + except asyncio.exceptions.TimeoutError: + logger.warning("等待连接所有直播间超时, 请检查是否存在未连接成功的直播间") # 启动动态推送模块 asyncio.get_event_loop().create_task(dynamic_spider(self.__datasource)) diff --git a/starbot/utils/config.py b/starbot/utils/config.py index e123ce7..34c0517 100644 --- a/starbot/utils/config.py +++ b/starbot/utils/config.py @@ -108,11 +108,11 @@ SIMPLE_CONFIG = { # 每个群动态 @ 我命令人数上限,单次 @ 人数过多容易被风控,不推荐修改 "COMMAND_DYNAMIC_AT_ME_LIMIT": 20, - # 是否启用风控消息补发 + # 是否启用风控消息补发,暂未实现 "BAN_RESEND": False, - # 风控发送失败消息滞留时间上限,消息因风控滞留超出此时长不会进行补发,0 为无限制,单位:秒 + # 风控发送失败消息滞留时间上限,消息因风控滞留超出此时长不会进行补发,0 为无限制,单位:秒,暂未实现 "RESEND_TIME_LIMIT": 0, - # 是否补发开播推送、下播推送、直播报告、动态推送中的 @全体成员 和 @群成员 消息,可能造成不必要的打扰,不推荐开启 + # 是否补发开播推送、下播推送、直播报告、动态推送中的 @全体成员 和 @群成员 消息,可能造成不必要的打扰,不推荐开启,暂未实现 "RESEND_AT_MESSAGE": False } @@ -224,11 +224,11 @@ FULL_CONFIG = { # 每个群动态 @ 我命令人数上限,单次 @ 人数过多容易被风控,不推荐修改 "COMMAND_DYNAMIC_AT_ME_LIMIT": 20, - # 是否启用风控消息补发 + # 是否启用风控消息补发,暂未实现 "BAN_RESEND": True, - # 风控发送失败消息滞留时间上限,消息因风控滞留超出此时长不会进行补发,0 为无限制,单位:秒 + # 风控发送失败消息滞留时间上限,消息因风控滞留超出此时长不会进行补发,0 为无限制,单位:秒,暂未实现 "RESEND_TIME_LIMIT": 0, - # 是否补发开播推送、下播推送、直播报告、动态推送中的 @全体成员 和 @群成员 消息,可能造成不必要的打扰,不推荐开启 + # 是否补发开播推送、下播推送、直播报告、动态推送中的 @全体成员 和 @群成员 消息,可能造成不必要的打扰,不推荐开启,暂未实现 "RESEND_AT_MESSAGE": False }