From 9a5c4c038e54122dea3d25acf16fc914150dc922 Mon Sep 17 00:00:00 2001
From: dbrockmann <dominiktobin@gmail.com>
Date: Thu, 19 Mar 2026 13:21:53 +0000
Subject: [PATCH] test: add e2e interruption test

---
 tests/test_e2e.py | 27 +++++++++++++++++++++++++++
 1 file changed, 27 insertions(+)

diff --git a/tests/test_e2e.py b/tests/test_e2e.py
index b25de2a..f729aa0 100644
--- a/tests/test_e2e.py
+++ b/tests/test_e2e.py
@@ -26,6 +26,7 @@
 from fastmcp import FastMCP
 from joinly_client import JoinlyClient
 from joinly_client.types import TranscriptSegment
+from mcp.types import TextContent
 from PIL import Image
 
 MEETING_URL = os.environ.get("JOINLY_TEST_MEETING_URL")
@@ -266,6 +267,32 @@ async def _on_segments(segs: list[TranscriptSegment]) -> None:
         remove()
 
 
+async def test_speech_interruption(
+    bots: tuple[JoinlyClient, JoinlyClient],
+) -> None:
+    """Speaking while another bot is already speaking should be interrupted."""
+    bot_a, bot_b = bots
+
+    # Bot A starts a long speech
+    task_a = asyncio.create_task(
+        bot_a.client.call_tool(
+            "speak_text",
+            {"text": "One two three four five six seven eight nine ten."},
+        )
+    )
+    await asyncio.sleep(2)
+
+    # Bot B tries to speak over Bot A, should be interrupted immediately
+    result_b = await bot_b.client.call_tool("speak_text", {"text": "Hello."})
+    result_text = " ".join(
+        p.text for p in result_b.content if isinstance(p, TextContent)
+    )
+    assert "interrupted" in result_text.lower(), (
+        f"Expected Bot B to be interrupted, got: {result_text}"
+    )
+    await task_a
+
+
 async def test_video_snapshot_is_valid_image(
     bots: tuple[JoinlyClient, JoinlyClient],
 ) -> None: