remove:移除info_catcher

Author: SengokuCola

docs/develop/plugin_develop/index.md

@@ -12,7 +12,6 @@
 from src.chat.emoji_system.emoji_manager import emoji_manager
 from src.chat.focus_chat.heartFC_sender import HeartFCSender
 from src.chat.utils.utils import process_llm_response
-from src.chat.utils.info_catcher import info_catcher_manager
 from src.chat.heart_flow.utils_chat import get_chat_type_and_target_info
 from src.chat.message_receive.chat_stream import ChatStream
 from src.chat.focus_chat.hfc_utils import parse_thinking_id_to_timestamp
@@ -186,9 +185,6 @@ async def express(
             # current_temp = float(global_config.model.normal["temp"]) * arousal_multiplier
             # self.express_model.params["temperature"] = current_temp  # 动态调整温度
 
-            # 2. 获取信息捕捉器
-            info_catcher = info_catcher_manager.get_info_catcher(thinking_id)
-
             # --- Determine sender_name for private chat ---
             sender_name_for_prompt = "某人"  # Default for group or if info unavailable
             if not self.is_group_chat and self.chat_target_info:
@@ -227,14 +223,10 @@ async def express(
                     # logger.info(f"{self.log_prefix}[Replier-{thinking_id}]\nPrompt:\n{prompt}\n")
                     content, (reasoning_content, model_name) = await self.express_model.generate_response_async(prompt)
 
-                    # logger.info(f"{self.log_prefix}\nPrompt:\n{prompt}\n---------------------------\n")
-
                     logger.info(f"想要表达：{in_mind_reply}||理由：{reason}")
                     logger.info(f"最终回复: {content}\n")
 
-                info_catcher.catch_after_llm_generated(
-                    prompt=prompt, response=content, reasoning_content=reasoning_content, model_name=model_name
-                )
+
 
             except Exception as llm_e:
                 # 精简报错信息

src/chat/focus_chat/expressors/default_expressor.py

@@ -110,7 +110,9 @@ async def send_message(self, message: MessageSending, has_thinking=False, typing
                     message.set_reply()
                     logger.debug(f"[{chat_id}] 应用 set_reply 逻辑: {message.processed_plain_text[:20]}...")
 
+            # print(f"message.display_message: {message.display_message}")
             await message.process()
+            # print(f"message.display_message: {message.display_message}")
 
             if typing:
                 if has_thinking:

src/chat/focus_chat/heartFC_sender.py

@@ -12,7 +12,6 @@
 from src.chat.emoji_system.emoji_manager import emoji_manager
 from src.chat.focus_chat.heartFC_sender import HeartFCSender
 from src.chat.utils.utils import process_llm_response
-from src.chat.utils.info_catcher import info_catcher_manager
 from src.chat.heart_flow.utils_chat import get_chat_type_and_target_info
 from src.chat.message_receive.chat_stream import ChatStream
 from src.chat.focus_chat.hfc_utils import parse_thinking_id_to_timestamp
@@ -238,8 +237,6 @@ async def reply(
             # current_temp = float(global_config.model.normal["temp"]) * arousal_multiplier
             # self.express_model.params["temperature"] = current_temp  # 动态调整温度
 
-            # 2. 获取信息捕捉器
-            info_catcher = info_catcher_manager.get_info_catcher(thinking_id)
 
             reply_to = action_data.get("reply_to", "none")
 
@@ -286,10 +283,6 @@ async def reply(
                     # logger.info(f"prompt: {prompt}")
                     logger.info(f"最终回复: {content}")
 
-                info_catcher.catch_after_llm_generated(
-                    prompt=prompt, response=content, reasoning_content=reasoning_content, model_name=model_name
-                )
-
             except Exception as llm_e:
                 # 精简报错信息
                 logger.error(f"{self.log_prefix}LLM 生成失败: {llm_e}")

src/chat/focus_chat/replyer/default_replyer.py

@@ -24,6 +24,7 @@ async def store_message(message: Union[MessageSending, MessageRecv], chat_stream
             else:
                 filtered_processed_plain_text = ""
 
+            
             if isinstance(message, MessageSending):
                 display_message = message.display_message
                 if display_message:

src/chat/message_receive/storage.py

@@ -8,7 +8,6 @@
 from src.chat.heart_flow.utils_chat import get_chat_type_and_target_info
 from src.manager.mood_manager import mood_manager
 from src.chat.message_receive.chat_stream import ChatStream, chat_manager
-from src.chat.utils.info_catcher import info_catcher_manager
 from src.chat.utils.timer_calculator import Timer
 from src.chat.utils.prompt_builder import global_prompt_manager
 from .normal_chat_generator import NormalChatGenerator
@@ -277,9 +276,6 @@ async def normal_response(self, message: MessageRecv, is_mentioned: bool, intere
 
             logger.debug(f"[{self.stream_name}] 创建捕捉器，thinking_id:{thinking_id}")
 
-            info_catcher = info_catcher_manager.get_info_catcher(thinking_id)
-            info_catcher.catch_decide_to_response(message)
-
             # 如果启用planner，预先修改可用actions（避免在并行任务中重复调用）
             available_actions = None
             if self.enable_planner:
@@ -373,8 +369,6 @@ async def plan_and_execute_actions():
             if isinstance(response_set, Exception):
                 logger.error(f"[{self.stream_name}] 回复生成异常: {response_set}")
                 response_set = None
-            elif response_set:
-                info_catcher.catch_after_generate_response(timing_results["并行生成回复和规划"])
 
             # 处理规划结果（可选，不影响回复）
             if isinstance(plan_result, Exception):
@@ -414,7 +408,6 @@ async def plan_and_execute_actions():
 
             # 检查 first_bot_msg 是否为 None (例如思考消息已被移除的情况)
             if first_bot_msg:
-                info_catcher.catch_after_response(timing_results["消息发送"], response_set, first_bot_msg)
 
                 # 记录回复信息到最近回复列表中
                 reply_info = {
@@ -447,8 +440,6 @@ async def plan_and_execute_actions():
                         # await self._check_switch_to_focus()
                         pass
 
-            info_catcher.done_catch()
-
             with Timer("处理表情包", timing_results):
                 await self._handle_emoji(message, response_set[0])
 

src/chat/normal_chat/normal_chat.py

@@ -133,6 +133,7 @@ async def send_response_messages(
                 thinking_start_time=time.time(),
                 reply_to=mark_head,
                 is_emoji=is_emoji,
+                display_message=display_message,
             )
             logger.debug(f"{self.log_prefix} 添加{response_type}类型消息: {content}")
 
@@ -167,6 +168,7 @@ async def _build_sending_message(
         thinking_start_time: float,
         reply_to: bool = False,
         is_emoji: bool = False,
+        display_message: str = "",
     ) -> MessageSending:
         """构建发送消息
 
@@ -197,6 +199,7 @@ async def _build_sending_message(
             reply=anchor_message if reply_to else None,
             thinking_start_time=thinking_start_time,
             is_emoji=is_emoji,
+            display_message=display_message,
         )
 
         return message_sending

src/chat/normal_chat/normal_chat_expressor.py

@@ -6,7 +6,6 @@
 from src.chat.normal_chat.normal_prompt import prompt_builder
 from src.chat.utils.timer_calculator import Timer
 from src.common.logger_manager import get_logger
-from src.chat.utils.info_catcher import info_catcher_manager
 from src.person_info.person_info import person_info_manager
 from src.chat.utils.utils import process_llm_response
 
@@ -69,7 +68,6 @@ async def _generate_response_with_model(
         enable_planner: bool = False,
         available_actions=None,
     ):
-        info_catcher = info_catcher_manager.get_info_catcher(thinking_id)
 
         person_id = person_info_manager.get_person_id(
             message.chat_stream.user_info.platform, message.chat_stream.user_info.user_id
@@ -105,9 +103,6 @@ async def _generate_response_with_model(
 
             logger.info(f"对  {message.processed_plain_text}  的回复：{content}")
 
-            info_catcher.catch_after_llm_generated(
-                prompt=prompt, response=content, reasoning_content=reasoning_content, model_name=self.current_model_name
-            )
 
         except Exception:
             logger.exception("生成回复时出错")

src/chat/normal_chat/normal_chat_generator.py

@@ -150,7 +150,7 @@ async def plan(self, message: MessageThinking, sender_name: str = "某人") -> D
             try:
                 content, (reasoning_content, model_name) = await self.planner_llm.generate_response_async(prompt)
 
-                logger.info(f"{self.log_prefix}规划器原始提示词: {prompt}")
+                # logger.info(f"{self.log_prefix}规划器原始提示词: {prompt}")
                 logger.info(f"{self.log_prefix}规划器原始响应: {content}")
                 logger.info(f"{self.log_prefix}规划器推理: {reasoning_content}")
                 logger.info(f"{self.log_prefix}规划器模型: {model_name}")