mirror/nanobot
1
0
Fork 0
mirror of https://github.com/HKUDS/nanobot.git synced 2026-05-04 16:55:54 +00:00
Code Issues Packages Projects Releases Wiki Activity

fix(telegram): split oversized final streamed replies

Browse Source 
Prevent Telegram Message_too_long failures on stream finalization by editing only the first chunk and sending overflow chunks as follow-up messages.

Made-with: Cursor
This commit is contained in:
Michael-lhh 2026-03-26 22:38:40 +08:00
parent 33abe915e7
commit e8e85cd1bc
1 changed files with 11 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
nanobot/channels/telegram.py
View File

@ -498,8 +498,10 @@ class TelegramChannel(BaseChannel):
if stream_id is not None and buf.stream_id is not None and buf.stream_id != stream_id: if stream_id is not None and buf.stream_id is not None and buf.stream_id != stream_id:
return return
self._stop_typing(chat_id) self._stop_typing(chat_id)
chunks = split_message(buf.text, TELEGRAM_MAX_MESSAGE_LEN)
primary_text = chunks[0] if chunks else buf.text
try: try:
html = _markdown_to_telegram_html(buf.text) html = _markdown_to_telegram_html(primary_text)
await self._call_with_retry( await self._call_with_retry(
self._app.bot.edit_message_text, self._app.bot.edit_message_text,
chat_id=int_chat_id, message_id=buf.message_id, chat_id=int_chat_id, message_id=buf.message_id,
@ -515,15 +517,18 @@ class TelegramChannel(BaseChannel):
await self._call_with_retry( await self._call_with_retry(
self._app.bot.edit_message_text, self._app.bot.edit_message_text,
chat_id=int_chat_id, message_id=buf.message_id, chat_id=int_chat_id, message_id=buf.message_id,
text=buf.text, text=primary_text,
) )
except Exception as e2: except Exception as e2:
if self._is_not_modified_error(e2): if self._is_not_modified_error(e2):
logger.debug("Final stream plain edit already applied for {}", chat_id) logger.debug("Final stream plain edit already applied for {}", chat_id)
self._stream_bufs.pop(chat_id, None) else:
return
logger.warning("Final stream edit failed: {}", e2) logger.warning("Final stream edit failed: {}", e2)
raise # Let ChannelManager handle retry raise # Let ChannelManager handle retry
# If final content exceeds Telegram limit, keep the first chunk in
# the edited stream message and send the rest as follow-up messages.
for extra_chunk in chunks[1:]:
await self._send_text(int_chat_id, extra_chunk)
self._stream_bufs.pop(chat_id, None) self._stream_bufs.pop(chat_id, None)
return return