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

feat：heartFC模式堂堂登场

Browse Source
This commit is contained in:
SengokuCola
2025-04-16 22:30:58 +08:00
parent b4f284abca
commit d467bf2779
7 changed files with 1372 additions and 78 deletions
Download Patch File Download Diff File Expand all files Collapse all files

149
src/heart_flow/sub_heartflow.py
View File

@@ -58,6 +58,19 @@ def init_prompt():
prompt += "现在你接下去继续思考，产生新的想法，记得保留你刚刚的想法，不要分点输出，输出连贯的内心独白"
prompt += "不要太长，但是记得结合上述的消息，要记得你的人设，关注聊天和新内容，关注你回复的内容，不要思考太多:"
Prompt(prompt, "sub_heartflow_prompt_after")
# prompt += f"你现在正在做的事情是：{schedule_info}\n"
prompt += "{extra_info}\n"
prompt += "{prompt_personality}\n"
prompt += "现在是{time_now}，你正在上网，和qq群里的网友们聊天，群里正在聊的话题是：\n{chat_observe_info}\n"
prompt += "刚刚你的想法是{current_thinking_info}。"
prompt += "你现在看到了网友们发的新消息:{message_new_info}\n"
# prompt += "你刚刚回复了群友们:{reply_info}"
prompt += "你现在{mood_info}"
prompt += "现在你接下去继续思考，产生新的想法，记得保留你刚刚的想法，不要分点输出，输出连贯的内心独白"
prompt += "不要思考太多，不要输出多余内容(包括前后缀，冒号和引号，括号， 表情，等)，不要带有括号和动作描写"
prompt += "记得结合上述的消息，生成内心想法，文字不要浮夸，注意{bot_name}指的就是你。"
Prompt(prompt, "sub_heartflow_prompt_after_observe")
class CurrentState:
@@ -262,9 +275,25 @@ class SubHeartflow:
logger.info(f"prompt:\n{prompt}\n")
logger.info(f"麦麦的思考前脑内状态：{self.current_mind}")
return self.current_mind, self.past_mind
async def do_thinking_after_observe(
self, message_txt: str, sender_info: UserInfo, chat_stream: ChatStream, extra_info: str, obs_id: int = None
):
current_thinking_info = self.current_mind
mood_info = self.current_state.mood
# mood_info = "你很生气，很愤怒"
observation = self.observations[0]
if obs_id:
print(f"11111111111有id,开始获取观察信息{obs_id}")
chat_observe_info = observation.get_observe_info(obs_id)
else:
chat_observe_info = observation.get_observe_info()
async def do_thinking_after_reply(self, reply_content, chat_talking_prompt, extra_info):
# print("麦麦回复之后脑袋转起来了")
extra_info_prompt = ""
for tool_name, tool_data in extra_info.items():
extra_info_prompt += f"{tool_name} 相关信息:\n"
for item in tool_data:
extra_info_prompt += f"- {item['name']}: {item['content']}\n"
# 开始构建prompt
prompt_personality = f"你的名字是{self.bot_name},你"
@@ -274,12 +303,6 @@ class SubHeartflow:
personality_core = individuality.personality.personality_core
prompt_personality += personality_core
extra_info_prompt = ""
for tool_name, tool_data in extra_info.items():
extra_info_prompt += f"{tool_name} 相关信息:\n"
for item in tool_data:
extra_info_prompt += f"- {item['name']}: {item['content']}\n"
personality_sides = individuality.personality.personality_sides
random.shuffle(personality_sides)
prompt_personality += f",{personality_sides[0]}"
@@ -288,26 +311,47 @@ class SubHeartflow:
random.shuffle(identity_detail)
prompt_personality += f",{identity_detail[0]}"
current_thinking_info = self.current_mind
mood_info = self.current_state.mood
# 关系
who_chat_in_group = [
(chat_stream.user_info.platform, chat_stream.user_info.user_id, chat_stream.user_info.user_nickname)
]
who_chat_in_group += get_recent_group_speaker(
chat_stream.stream_id,
(chat_stream.user_info.platform, chat_stream.user_info.user_id),
limit=global_config.MAX_CONTEXT_SIZE,
)
observation = self.observations[0]
chat_observe_info = observation.observe_info
relation_prompt = ""
for person in who_chat_in_group:
relation_prompt += await relationship_manager.build_relationship_info(person)
# relation_prompt_all = (
# f"{relation_prompt}关系等级越大，关系越好，请分析聊天记录，"
# f"根据你和说话者{sender_name}的关系和态度进行回复，明确你的立场和情感。"
# )
relation_prompt_all = (await global_prompt_manager.get_prompt_async("relationship_prompt")).format(
relation_prompt, sender_info.user_nickname
)
sender_name_sign = (
f"<{chat_stream.platform}:{sender_info.user_id}:{sender_info.user_nickname}:{sender_info.user_cardname}>"
)
message_new_info = chat_talking_prompt
reply_info = reply_content
time_now = time.strftime("%Y-%m-%d %H:%M:%S", time.localtime())
prompt = (await global_prompt_manager.get_prompt_async("sub_heartflow_prompt_after")).format(
prompt = (await global_prompt_manager.get_prompt_async("sub_heartflow_prompt_after_observe")).format(
extra_info_prompt,
# prompt_schedule,
relation_prompt_all,
prompt_personality,
current_thinking_info,
time_now,
chat_observe_info,
current_thinking_info,
message_new_info,
reply_info,
mood_info,
sender_name_sign,
message_txt,
self.bot_name,
)
prompt = await relationship_manager.convert_all_person_sign_to_person_name(prompt)
@@ -316,14 +360,77 @@ class SubHeartflow:
try:
response, reasoning_content = await self.llm_model.generate_response_async(prompt)
except Exception as e:
logger.error(f"回复后内心独白获取失败: {e}")
logger.error(f"回复前内心独白获取失败: {e}")
response = ""
self.update_current_mind(response)
self.current_mind = response
logger.info(f"麦麦回复后的脑内状态：{self.current_mind}")
self.last_reply_time = time.time()
logger.info(f"prompt:\n{prompt}\n")
logger.info(f"麦麦的思考前脑内状态：{self.current_mind}")
return self.current_mind, self.past_mind
# async def do_thinking_after_reply(self, reply_content, chat_talking_prompt, extra_info):
# # print("麦麦回复之后脑袋转起来了")
# # 开始构建prompt
# prompt_personality = f"你的名字是{self.bot_name},你"
# # person
# individuality = Individuality.get_instance()
# personality_core = individuality.personality.personality_core
# prompt_personality += personality_core
# extra_info_prompt = ""
# for tool_name, tool_data in extra_info.items():
# extra_info_prompt += f"{tool_name} 相关信息:\n"
# for item in tool_data:
# extra_info_prompt += f"- {item['name']}: {item['content']}\n"
# personality_sides = individuality.personality.personality_sides
# random.shuffle(personality_sides)
# prompt_personality += f",{personality_sides[0]}"
# identity_detail = individuality.identity.identity_detail
# random.shuffle(identity_detail)
# prompt_personality += f",{identity_detail[0]}"
# current_thinking_info = self.current_mind
# mood_info = self.current_state.mood
# observation = self.observations[0]
# chat_observe_info = observation.observe_info
# message_new_info = chat_talking_prompt
# reply_info = reply_content
# time_now = time.strftime("%Y-%m-%d %H:%M:%S", time.localtime())
# prompt = (await global_prompt_manager.get_prompt_async("sub_heartflow_prompt_after")).format(
# extra_info_prompt,
# prompt_personality,
# time_now,
# chat_observe_info,
# current_thinking_info,
# message_new_info,
# reply_info,
# mood_info,
# )
# prompt = await relationship_manager.convert_all_person_sign_to_person_name(prompt)
# prompt = parse_text_timestamps(prompt, mode="lite")
# try:
# response, reasoning_content = await self.llm_model.generate_response_async(prompt)
# except Exception as e:
# logger.error(f"回复后内心独白获取失败: {e}")
# response = ""
# self.update_current_mind(response)
# self.current_mind = response
# logger.info(f"麦麦回复后的脑内状态：{self.current_mind}")
# self.last_reply_time = time.time()
def update_current_mind(self, response):
self.past_mind.append(self.current_mind)