refactor(chat): 从 MessageManager 中移除睡眠和唤醒管理器的残留代码
在之前的提交 (cb51446) 中,睡眠管理器模块已被移除。本次提交清除了 `MessageManager` 中与之相关的残留代码,包括导入语句、实例初始化以及启动/停止逻辑,完成了整个重构过程。
This commit is contained in:
@@ -19,8 +19,6 @@ from src.config.config import global_config
|
|||||||
from src.plugin_system.apis.chat_api import get_chat_manager
|
from src.plugin_system.apis.chat_api import get_chat_manager
|
||||||
|
|
||||||
from .distribution_manager import stream_loop_manager
|
from .distribution_manager import stream_loop_manager
|
||||||
from .sleep_manager.sleep_manager import SleepManager
|
|
||||||
from .sleep_manager.wakeup_manager import WakeUpManager
|
|
||||||
|
|
||||||
if TYPE_CHECKING:
|
if TYPE_CHECKING:
|
||||||
pass
|
pass
|
||||||
@@ -43,10 +41,6 @@ class MessageManager:
|
|||||||
self.action_manager = ChatterActionManager()
|
self.action_manager = ChatterActionManager()
|
||||||
self.chatter_manager = ChatterManager(self.action_manager)
|
self.chatter_manager = ChatterManager(self.action_manager)
|
||||||
|
|
||||||
# 初始化睡眠和唤醒管理器
|
|
||||||
self.sleep_manager = SleepManager()
|
|
||||||
self.wakeup_manager = WakeUpManager(self.sleep_manager)
|
|
||||||
|
|
||||||
# 消息缓存系统 - 直接集成到消息管理器
|
# 消息缓存系统 - 直接集成到消息管理器
|
||||||
self.message_caches: Dict[str, deque] = defaultdict(deque) # 每个流的消息缓存
|
self.message_caches: Dict[str, deque] = defaultdict(deque) # 每个流的消息缓存
|
||||||
self.stream_processing_status: Dict[str, bool] = defaultdict(bool) # 流的处理状态
|
self.stream_processing_status: Dict[str, bool] = defaultdict(bool) # 流的处理状态
|
||||||
@@ -94,7 +88,6 @@ class MessageManager:
|
|||||||
logger.error(f"启动自适应流管理器失败: {e}")
|
logger.error(f"启动自适应流管理器失败: {e}")
|
||||||
|
|
||||||
# 启动睡眠和唤醒管理器
|
# 启动睡眠和唤醒管理器
|
||||||
await self.wakeup_manager.start()
|
|
||||||
|
|
||||||
# 启动流循环管理器并设置chatter_manager
|
# 启动流循环管理器并设置chatter_manager
|
||||||
await stream_loop_manager.start()
|
await stream_loop_manager.start()
|
||||||
@@ -141,8 +134,6 @@ class MessageManager:
|
|||||||
except Exception as e:
|
except Exception as e:
|
||||||
logger.error(f"停止自适应流管理器失败: {e}")
|
logger.error(f"停止自适应流管理器失败: {e}")
|
||||||
|
|
||||||
# 停止睡眠和唤醒管理器
|
|
||||||
await self.wakeup_manager.stop()
|
|
||||||
|
|
||||||
# 停止流循环管理器
|
# 停止流循环管理器
|
||||||
await stream_loop_manager.stop()
|
await stream_loop_manager.stop()
|
||||||
|
|||||||
Reference in New Issue
Block a user