Merge branch 'dev' of https://github.com/MoFox-Studio/MoFox_Bot into dev

src/chat/chat_loop/proactive/event_scheduler.py

@@ -4,9 +4,8 @@
 """
 
 import asyncio
-import time
 import traceback
-from datetime import datetime, timedelta
+from datetime import datetime
 from typing import Dict, Callable, Any, Optional
 from dataclasses import dataclass
 from src.common.logger import get_logger

src/chat/chat_loop/proactive/proactive_thinker.py

@@ -1,7 +1,5 @@
 import time
 import traceback
-import orjson
-import re
 from typing import TYPE_CHECKING, Dict, Any
 
 from src.common.logger import get_logger
@@ -12,7 +10,6 @@ from src.plugin_system.apis import generator_api
 from src.plugin_system.apis.generator_api import process_human_text
 from src.schedule.schedule_manager import schedule_manager
 from src.plugin_system import tool_api
-from src.plugin_system.base.component_types import ComponentType
 from src.config.config import global_config
 from src.chat.utils.chat_message_builder import get_raw_msg_before_timestamp_with_chat, build_readable_messages_with_id
 from src.mood.mood_manager import mood_manager

src/chat/chat_loop/response_handler.py

@@ -1,5 +1,4 @@
 import time
-import orjson
 import random
 from typing import Dict, Any, Tuple
 

src/chat/chat_loop/sleep_manager/notification_sender.py

@@ -1,4 +1,3 @@
-import asyncio
 from src.common.logger import get_logger
 from ..hfc_context import HfcContext
 

src/chat/chat_loop/sleep_manager/sleep_manager.py

@@ -1,7 +1,7 @@
 import asyncio
 import random
 from datetime import datetime, timedelta, date
-from typing import Optional, TYPE_CHECKING, List, Dict, Any
+from typing import Optional, TYPE_CHECKING
 
 from src.common.logger import get_logger
 from src.config.config import global_config

src/chat/frequency_analyzer/trigger.py

@@ -91,7 +91,7 @@ class FrequencyBasedTrigger:
                         # 6. 直接调用 proactive_thinker
                         event = ProactiveTriggerEvent(
                             source="frequency_analyzer",
-                            reason=f"User is in a high-frequency chat period."
+                            reason="User is in a high-frequency chat period."
                         )
                         await sub_heartflow.heart_fc_instance.proactive_thinker.think(event)
                         

src/chat/heart_flow/heartflow_message_processor.py

@@ -17,7 +17,6 @@ from src.chat.utils.chat_message_builder import replace_user_references_sync
 from src.common.logger import get_logger
 from src.person_info.relationship_manager import get_relationship_manager
 from src.mood.mood_manager import mood_manager
-from src.chat.message_receive.chat_stream import get_chat_manager
 
 if TYPE_CHECKING:
     from src.chat.heart_flow.sub_heartflow import SubHeartflow

src/chat/planner_actions/planner.py

@@ -1,10 +1,7 @@
 import orjson
 import time
 import traceback
-import asyncio
-import math
 import random
-import json
 from typing import Dict, Any, Optional, Tuple, List, TYPE_CHECKING
 from rich.traceback import install
 from datetime import datetime
@@ -27,7 +24,6 @@ from src.plugin_system.base.component_types import (
     ActionInfo,
     ChatMode,
     ComponentType,
-    ActionActivationType,
 )
 from src.plugin_system.core.component_registry import component_registry
 from src.schedule.schedule_manager import schedule_manager

src/common/message/api.py

@@ -1,5 +1,4 @@
 from src.common.server import get_global_server
-import os
 import importlib.metadata
 from maim_message import MessageServer
 from src.common.logger import get_logger

src/config/official_configs.py

@@ -662,9 +662,6 @@ class SleepSystemConfig(ValidatedConfigBase):
     )
     max_sleep_delay_minutes: int = Field(default=60, description="单日最大延迟入睡分钟数")
     enable_pre_sleep_notification: bool = Field(default=True, description="是否启用睡前消息")
-    pre_sleep_notification_groups: List[str] = Field(
-        default_factory=list, description='接收睡前消息的群号列表, 格式: ["platform:group_id1", "platform:group_id2"]'
-    )
     pre_sleep_prompt: str = Field(
         default="我准备睡觉了，请生成一句简短自然的晚安问候。", description="用于生成睡前消息的提示"
     )

src/plugin_system/base/base_action.py

@@ -8,6 +8,7 @@ from src.common.logger import get_logger
 from src.chat.message_receive.chat_stream import ChatStream
 from src.plugin_system.base.component_types import ActionActivationType, ChatMode, ActionInfo, ComponentType, ChatType
 from src.plugin_system.apis import send_api, database_api, message_api
+from src.plugin_system.core.component_registry import component_registry
 
 
 logger = get_logger("base_action")
@@ -381,6 +382,60 @@ class BaseAction(ABC):
             logger.error(f"{self.log_prefix} 发送命令时出错: {e}")
             return False
 
+    async def call_action(self, action_name: str, action_data: Optional[dict] = None) -> Tuple[bool, str]:
+        """
+        在当前Action中调用另一个Action。
+
+        Args:
+            action_name (str): 要调用的Action的名称。
+            action_data (Optional[dict], optional): 传递给被调用Action的动作数据。如果为None，则使用当前Action的action_data。
+
+        Returns:
+            Tuple[bool, str]: 被调用Action的执行结果 (is_success, message)。
+        """
+        log_prefix = f"{self.log_prefix} [call_action -> {action_name}]"
+        logger.info(f"{log_prefix} 尝试调用Action: {action_name}")
+
+        try:
+            # 1. 从注册中心获取Action类
+            action_class = component_registry.get_component_class(action_name, ComponentType.ACTION)
+            if not action_class:
+                logger.error(f"{log_prefix} 未找到Action: {action_name}")
+                return False, f"未找到Action: {action_name}"
+
+            # 2. 准备实例化参数
+            # 复用当前Action的大部分上下文信息
+            called_action_data = action_data if action_data is not None else self.action_data
+            
+            component_info = component_registry.get_component_info(action_name, ComponentType.ACTION)
+            if not component_info:
+                logger.warning(f"{log_prefix} 未找到Action组件信息: {action_name}")
+                return False, f"未找到Action组件信息: {action_name}"
+
+            plugin_config = component_registry.get_plugin_config(component_info.plugin_name)
+
+            # 3. 实例化被调用的Action
+            action_instance = action_class(
+                action_data=called_action_data,
+                reasoning=f"Called by {self.action_name}",
+                cycle_timers=self.cycle_timers,
+                thinking_id=self.thinking_id,
+                chat_stream=self.chat_stream,
+                log_prefix=log_prefix,
+                plugin_config=plugin_config,
+                action_message=self.action_message,
+            )
+
+            # 4. 执行Action
+            logger.debug(f"{log_prefix} 开始执行...")
+            result = await action_instance.execute()
+            logger.info(f"{log_prefix} 执行完成，结果: {result}")
+            return result
+
+        except Exception as e:
+            logger.error(f"{log_prefix} 调用时发生错误: {e}", exc_info=True)
+            return False, f"调用Action '{action_name}' 时发生错误: {e}"
+
     @classmethod
     def get_action_info(cls) -> "ActionInfo":
         """从类属性生成ActionInfo

src/plugins/built_in/at_user_plugin/plugin.py

@@ -8,7 +8,6 @@ from src.plugin_system import (
     ActionInfo,
     ActionActivationType,
 )
-from src.person_info.person_info import get_person_info_manager
 from src.common.logger import get_logger
 from src.plugin_system.base.component_types import ChatType
 

src/plugins/built_in/napcat_adapter_plugin/event_handlers.py

@@ -1,4 +1,3 @@
-import orjson
 
 from src.plugin_system import BaseEventHandler
 from src.plugin_system.base.base_event import HandlerResult