gardel/Mofox-Core
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

fix：缺少stream的报错

Browse Source
This commit is contained in:
SengokuCola
2025-08-08 21:20:28 +08:00
parent 090dd012e1
commit d1f15a932a
3 changed files with 4 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
src/chat/chat_loop/heartFC_chat.py
View File

@@ -386,7 +386,7 @@ class HeartFChatting:
chat_target_info=planner_info[1], chat_target_info=planner_info[1],
current_available_actions=planner_info[2], current_available_actions=planner_info[2],
) )
await events_manager.handle_mai_events(EventType.ON_PLAN, None, prompt_info[0], None) await events_manager.handle_mai_events(EventType.ON_PLAN, None, prompt_info[0], None, self.chat_stream.stream_id)
with Timer("规划器", cycle_timers): with Timer("规划器", cycle_timers):
plan_result, target_message = await self.action_planner.plan(mode=self.loop_mode) plan_result, target_message = await self.action_planner.plan(mode=self.loop_mode)

2
src/chat/message_receive/bot.py
View File

@@ -148,7 +148,7 @@ class ChatBot:
if message.message_info.message_id == "notice": if message.message_info.message_id == "notice":
message.is_notify = True message.is_notify = True
logger.info("notice消息") logger.info("notice消息")
print(message) # print(message)
return True return True

4
src/plugin_system/core/events_manager.py
View File

@@ -3,7 +3,7 @@ import contextlib
from typing import List, Dict, Optional, Type, Tuple from typing import List, Dict, Optional, Type, Tuple
from src.chat.message_receive.message import MessageRecv from src.chat.message_receive.message import MessageRecv
from src.chat.message_receive.chat_stream import chat_manager from src.chat.message_receive.chat_stream import get_chat_manager
from src.common.logger import get_logger from src.common.logger import get_logger
from src.plugin_system.base.component_types import EventType, EventHandlerInfo, MaiMessages from src.plugin_system.base.component_types import EventType, EventHandlerInfo, MaiMessages
from src.plugin_system.base.base_events_handler import BaseEventHandler from src.plugin_system.base.base_events_handler import BaseEventHandler
@@ -174,7 +174,7 @@ class EventsManager:
self, stream_id: str, llm_prompt: Optional[str] = None, llm_response: Optional[str] = None self, stream_id: str, llm_prompt: Optional[str] = None, llm_response: Optional[str] = None
) -> MaiMessages: ) -> MaiMessages:
"""从流ID构建消息""" """从流ID构建消息"""
chat_stream = chat_manager.get_stream(stream_id) chat_stream = get_chat_manager().get_stream(stream_id)
assert chat_stream, f"未找到流ID为 {stream_id} 的聊天流" assert chat_stream, f"未找到流ID为 {stream_id} 的聊天流"
message = chat_stream.context.get_last_message() message = chat_stream.context.get_last_message()
return self._transform_event_message(message, llm_prompt, llm_response) return self._transform_event_message(message, llm_prompt, llm_response)