feat：拆分expressor和replyer

src/chat/focus_chat/planners/action_manager.py

@@ -1,6 +1,7 @@
 from typing import Dict, List, Optional, Type, Any
 from src.chat.focus_chat.planners.actions.base_action import BaseAction, _ACTION_REGISTRY
 from src.chat.heart_flow.observation.observation import Observation
+from src.chat.focus_chat.replyer.default_replyer import DefaultReplyer
 from src.chat.focus_chat.expressors.default_expressor import DefaultExpressor
 from src.chat.message_receive.chat_stream import ChatStream
 from src.common.logger_manager import get_logger
@@ -135,6 +136,7 @@ class ActionManager:
         thinking_id: str,
         observations: List[Observation],
         expressor: DefaultExpressor,
+        replyer: DefaultReplyer,
         chat_stream: ChatStream,
         log_prefix: str,
         shutting_down: bool = False,
@@ -150,6 +152,7 @@ class ActionManager:
             thinking_id: 思考ID
             observations: 观察列表
             expressor: 表达器
+            replyer: 回复器
             chat_stream: 聊天流
             log_prefix: 日志前缀
             shutting_down: 是否正在关闭
@@ -176,6 +179,7 @@ class ActionManager:
                 thinking_id=thinking_id,
                 observations=observations,
                 expressor=expressor,
+                replyer=replyer,
                 chat_stream=chat_stream,
                 log_prefix=log_prefix,
                 shutting_down=shutting_down,

src/chat/focus_chat/planners/actions/plugin_action.py

@@ -45,6 +45,8 @@ class PluginAction(BaseAction):
             self._services["expressor"] = kwargs["expressor"]
         if "chat_stream" in kwargs:
             self._services["chat_stream"] = kwargs["chat_stream"]
+        if "replyer" in kwargs:
+            self._services["replyer"] = kwargs["replyer"]
 
         self.log_prefix = kwargs.get("log_prefix", "")
         self._load_plugin_config()  # 初始化时加载插件配置