github/deer-flow
1
0
Fork 0
mirror of https://github.com/bytedance/deer-flow.git synced 2026-10-26 21:26:39 +00:00
Code Issues Packages Projects Releases Wiki Activity

fix(channels): keep the delimiter newline when splitting long Discord replies (#6062)

Browse Source 
* fix(channels): preserve Discord split boundaries

* test(channels): cover Discord split at leading remainder newline

Signed-off-by: Willem Jiang <willem.jiang@gmail.com>

---------

Signed-off-by: Willem Jiang <willem.jiang@gmail.com>
Co-authored-by: Willem Jiang <willem.jiang@gmail.com>
This commit is contained in:
FanouZeng-TT 2026-09-30 10:17:46 +08:00 committed by GitHub
parent 9dc7bb30da
commit 4006ca072f
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
2 changed files with 29 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
backend/app/channels/discord.py
View File

@ -876,8 +876,12 @@ class DiscordChannel(Channel):
split_at = remaining.rfind("\n", 0, _DISCORD_MAX_MESSAGE_LEN)
if split_at <= 0:
split_at = _DISCORD_MAX_MESSAGE_LEN
else:
# Keep the delimiter on this chunk's tail so consecutive
# Discord messages reconstruct the original text exactly.
split_at += 1
chunks.append(remaining[:split_at])
remaining = remaining[split_at:].lstrip("\n")
remaining = remaining[split_at:]
if remaining:
chunks.append(remaining)

24
backend/tests/test_channels.py
View File

@ -6131,6 +6131,30 @@ class TestHandleChatWithArtifacts:
class TestDiscordChannel:
@pytest.mark.parametrize(
"text",
[
"x" * 1990 + "\n\n" + "y" * 30,
"x" * 2000 + "\n\n\n" + "y" * 30,
"x" * 2000 + "\n" + "y" * 2000,
("第一段\n\n" + "句" * 1990 + "\n\n最后一段") * 3,
"x" * 4500,
],
)
def test_split_text_preserves_content_within_discord_limit(self, text: str):
from app.channels.discord import _DISCORD_MAX_MESSAGE_LEN, DiscordChannel
chunks = DiscordChannel._split_text(text)
assert all(0 < len(chunk) <= _DISCORD_MAX_MESSAGE_LEN for chunk in chunks)
assert "".join(chunks) == text
def test_split_text_preserves_empty_and_short_messages(self):
from app.channels.discord import DiscordChannel
assert DiscordChannel._split_text("") == [""]
assert DiscordChannel._split_text("hello\n\nworld") == ["hello\n\nworld"]
def test_stop_prevents_queued_typing_starter_from_creating_task(self):
from app.channels.discord import DiscordChannel