tg适配器最后一次编辑转换markdown

This commit is contained in:
Raven95676
2025-04-07 00:47:52 +08:00
parent cfd3f4b199
commit 41bd76e091

View File

@@ -148,7 +148,7 @@ class TelegramPlatformEvent(AstrMessageEvent):
msg = await self.client.send_message(text=delta, **payload)
current_content = delta
except Exception as e:
logger.warning(f"发送消息失败(streaming): {e}")
logger.warning(f"发送消息失败(streaming): {e!s}")
message_id = msg.message_id
last_edit_time = (
asyncio.get_event_loop().time()
@@ -168,17 +168,31 @@ class TelegramPlatformEvent(AstrMessageEvent):
)
current_content = delta
except Exception as e:
logger.warning(f"编辑消息失败(streaming): {e}")
logger.warning(f"编辑消息失败(streaming): {e!s}")
last_edit_time = (
asyncio.get_event_loop().time()
) # 更新上次编辑的时间
try:
if delta and current_content != delta:
await self.client.edit_message_text(
text=delta, chat_id=payload["chat_id"], message_id=message_id
)
try:
markdown_text = telegramify_markdown.markdownify(
delta, max_line_length=None, normalize_whitespace=False
)
await self.client.edit_message_text(
text=markdown_text,
chat_id=payload["chat_id"],
message_id=message_id,
parse_mode="MarkdownV2"
)
except Exception as e:
logger.warning(f"Markdown转换失败使用普通文本: {e!s}")
await self.client.edit_message_text(
text=delta,
chat_id=payload["chat_id"],
message_id=message_id
)
except Exception as e:
logger.warning(f"编辑消息失败(streaming): {e}")
logger.warning(f"编辑消息失败(streaming): {e!s}")
return await super().send_streaming(generator)