rrrrrrrrrrrrruuuuuuuuuuuuuuuffffffffffffffffffffffffffff x3
This commit is contained in:
@@ -4,9 +4,8 @@
|
|||||||
"""
|
"""
|
||||||
|
|
||||||
import asyncio
|
import asyncio
|
||||||
import time
|
|
||||||
import traceback
|
import traceback
|
||||||
from datetime import datetime, timedelta
|
from datetime import datetime
|
||||||
from typing import Dict, Callable, Any, Optional
|
from typing import Dict, Callable, Any, Optional
|
||||||
from dataclasses import dataclass
|
from dataclasses import dataclass
|
||||||
from src.common.logger import get_logger
|
from src.common.logger import get_logger
|
||||||
|
|||||||
@@ -1,5 +1,4 @@
|
|||||||
import time
|
import time
|
||||||
import orjson
|
|
||||||
import random
|
import random
|
||||||
from typing import Dict, Any, Tuple
|
from typing import Dict, Any, Tuple
|
||||||
|
|
||||||
|
|||||||
@@ -1,4 +1,3 @@
|
|||||||
import asyncio
|
|
||||||
from src.common.logger import get_logger
|
from src.common.logger import get_logger
|
||||||
from ..hfc_context import HfcContext
|
from ..hfc_context import HfcContext
|
||||||
|
|
||||||
|
|||||||
@@ -1,7 +1,7 @@
|
|||||||
import asyncio
|
import asyncio
|
||||||
import random
|
import random
|
||||||
from datetime import datetime, timedelta, date
|
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.common.logger import get_logger
|
||||||
from src.config.config import global_config
|
from src.config.config import global_config
|
||||||
|
|||||||
@@ -91,7 +91,7 @@ class FrequencyBasedTrigger:
|
|||||||
# 6. 直接调用 proactive_thinker
|
# 6. 直接调用 proactive_thinker
|
||||||
event = ProactiveTriggerEvent(
|
event = ProactiveTriggerEvent(
|
||||||
source="frequency_analyzer",
|
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)
|
await sub_heartflow.heart_fc_instance.proactive_thinker.think(event)
|
||||||
|
|
||||||
|
|||||||
@@ -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.common.logger import get_logger
|
||||||
from src.person_info.relationship_manager import get_relationship_manager
|
from src.person_info.relationship_manager import get_relationship_manager
|
||||||
from src.mood.mood_manager import mood_manager
|
from src.mood.mood_manager import mood_manager
|
||||||
from src.chat.message_receive.chat_stream import get_chat_manager
|
|
||||||
|
|
||||||
if TYPE_CHECKING:
|
if TYPE_CHECKING:
|
||||||
from src.chat.heart_flow.sub_heartflow import SubHeartflow
|
from src.chat.heart_flow.sub_heartflow import SubHeartflow
|
||||||
|
|||||||
@@ -1,10 +1,7 @@
|
|||||||
import orjson
|
import orjson
|
||||||
import time
|
import time
|
||||||
import traceback
|
import traceback
|
||||||
import asyncio
|
|
||||||
import math
|
|
||||||
import random
|
import random
|
||||||
import json
|
|
||||||
from typing import Dict, Any, Optional, Tuple, List, TYPE_CHECKING
|
from typing import Dict, Any, Optional, Tuple, List, TYPE_CHECKING
|
||||||
from rich.traceback import install
|
from rich.traceback import install
|
||||||
from datetime import datetime
|
from datetime import datetime
|
||||||
@@ -27,7 +24,6 @@ from src.plugin_system.base.component_types import (
|
|||||||
ActionInfo,
|
ActionInfo,
|
||||||
ChatMode,
|
ChatMode,
|
||||||
ComponentType,
|
ComponentType,
|
||||||
ActionActivationType,
|
|
||||||
)
|
)
|
||||||
from src.plugin_system.core.component_registry import component_registry
|
from src.plugin_system.core.component_registry import component_registry
|
||||||
from src.schedule.schedule_manager import schedule_manager
|
from src.schedule.schedule_manager import schedule_manager
|
||||||
|
|||||||
@@ -1,5 +1,4 @@
|
|||||||
from src.common.server import get_global_server
|
from src.common.server import get_global_server
|
||||||
import os
|
|
||||||
import importlib.metadata
|
import importlib.metadata
|
||||||
from maim_message import MessageServer
|
from maim_message import MessageServer
|
||||||
from src.common.logger import get_logger
|
from src.common.logger import get_logger
|
||||||
|
|||||||
@@ -8,7 +8,6 @@ from src.plugin_system import (
|
|||||||
ActionInfo,
|
ActionInfo,
|
||||||
ActionActivationType,
|
ActionActivationType,
|
||||||
)
|
)
|
||||||
from src.person_info.person_info import get_person_info_manager
|
|
||||||
from src.common.logger import get_logger
|
from src.common.logger import get_logger
|
||||||
from src.plugin_system.base.component_types import ChatType
|
from src.plugin_system.base.component_types import ChatType
|
||||||
|
|
||||||
|
|||||||
@@ -1,4 +1,3 @@
|
|||||||
import orjson
|
|
||||||
|
|
||||||
from src.plugin_system import BaseEventHandler
|
from src.plugin_system import BaseEventHandler
|
||||||
from src.plugin_system.base.base_event import HandlerResult
|
from src.plugin_system.base.base_event import HandlerResult
|
||||||
|
|||||||
Reference in New Issue
Block a user