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

Update message_sender.py

Browse Source
This commit is contained in:
SengokuCola
2025-03-26 23:38:37 +08:00
parent 805bde0646
commit def7ee7ace
1 changed files with 4 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

7
src/plugins/chat/message_sender.py
View File

@@ -61,6 +61,7 @@ class Message_Sender:
if not is_recalled: if not is_recalled:
typing_time = calculate_typing_time(message.processed_plain_text) typing_time = calculate_typing_time(message.processed_plain_text)
logger.info(f"麦麦正在打字，预计需要{typing_time}秒")
await asyncio.sleep(typing_time) await asyncio.sleep(typing_time)
message_json = message.to_dict() message_json = message.to_dict()
@@ -99,7 +100,7 @@ class MessageContainer:
self.max_size = max_size self.max_size = max_size
self.messages = [] self.messages = []
self.last_send_time = 0 self.last_send_time = 0
self.thinking_timeout = 20 # 思考超时时间（秒） self.thinking_timeout = 10 # 思考超时时间（秒）
def get_timeout_messages(self) -> List[MessageSending]: def get_timeout_messages(self) -> List[MessageSending]:
"""获取所有超时的Message_Sending对象（思考时间超过30秒），按thinking_start_time排序""" """获取所有超时的Message_Sending对象（思考时间超过30秒），按thinking_start_time排序"""
@@ -208,7 +209,7 @@ class MessageManager:
# print(thinking_time) # print(thinking_time)
if ( if (
message_earliest.is_head message_earliest.is_head
and message_earliest.update_thinking_time() > 15 and message_earliest.update_thinking_time() > 20
and not message_earliest.is_private_message() # 避免在私聊时插入reply and not message_earliest.is_private_message() # 避免在私聊时插入reply
): ):
logger.debug(f"设置回复消息{message_earliest.processed_plain_text}") logger.debug(f"设置回复消息{message_earliest.processed_plain_text}")
@@ -235,7 +236,7 @@ class MessageManager:
# print(msg.is_private_message()) # print(msg.is_private_message())
if ( if (
msg.is_head msg.is_head
and msg.update_thinking_time() > 15 and msg.update_thinking_time() > 25
and not msg.is_private_message() # 避免在私聊时插入reply and not msg.is_private_message() # 避免在私聊时插入reply
): ):
logger.debug(f"设置回复消息{msg.processed_plain_text}") logger.debug(f"设置回复消息{msg.processed_plain_text}")