🔥 Feature: Add broadcast to bot and space

matrix/bot.py

@@ -7,6 +7,9 @@
 
 from nio import AsyncClient, Event, MatrixRoom
 
+from matrix.message import Message
+from matrix.types import File
+
 from .room import Room, make_room
 from .space import Space
 from .group import Group
@@ -423,3 +426,44 @@ async def _build_context(self, matrix_room: Room, event: Event) -> Context:
             ctx.command = cmd
 
         return ctx
+
+    # ROOMS
+
+    async def broadcast(
+        self,
+        rooms: list[Room],
+        content: str | None = None,
+        *,
+        raw: bool = False,
+        notice: bool = False,
+        file: File | None = None,
+    ) -> list[Message]:
+        """Broadcasts a message to the specified rooms.
+
+        Supports text messages (with optional markdown formatting)
+        and file uploads (including images, videos, and audio).
+        If a space is provided, it is silently skipped.
+
+        ## Example
+
+        ```python
+        # Broadcast a markdown-formatted text message
+        await bot.broadcast([room1, room2, ...], "Hello **world**!")
+
+        # Broadcast a notice message
+        await bot.broadcast([room1, room2, ...], "Event started", notice=True)
+
+        # Broadcast a file
+        file = File(path="mxc://...", filename="document.pdf", mimetype="application/pdf")
+        await bot.broadcast([room1, room2, ...], file=file)
+
+        # Broadcast an image
+        image = Image(path="mxc://...", filename="photo.jpg", mimetype="image/jpeg", width=800, height=600)
+        await bot.broadcast([room1, room2, ...], file=image)
+        ```
+        """
+        rooms = list(filter(lambda child: not isinstance(child, Space), rooms))
+        async_send = [
+            room.send(content, raw=raw, notice=notice, file=file) for room in rooms
+        ]
+        return await asyncio.gather(*async_send)

matrix/space.py

@@ -1,6 +1,11 @@
+import asyncio
+
+from matrix.message import Message
 from typing import Self
 from matrix.room import Room, make_room
 
+from matrix.types import File
+
 
 class Space(Room, room_type="m.space"):
     def get_children(self, depth: int = 1) -> list[Room | Self]:
@@ -43,3 +48,50 @@ def get_children(self, depth: int = 1) -> list[Room | Self]:
                 children.extend(child.get_children(depth - 1))
 
         return children
+
+    async def broadcast(
+        self,
+        content: str | None = None,
+        *,
+        raw: bool = False,
+        notice: bool = False,
+        file: File | None = None,
+        depth: int = 1,
+    ) -> list[Message]:
+        """Broadcasts a message to all rooms in this space.
+
+        Supports text messages (with optional markdown formatting)
+        and file uploads (including images, videos, and audio).
+
+        Children the bot has not joined are silently omitted. Use `depth` to
+        recursively broadcast to children of sub-spaces. `depth=1` broadcasts
+        to direct children only (default).
+
+        ## Example
+
+        ```python
+        # Broadcast a markdown-formatted text message
+        await space.broadcast("Hello **world**!")
+
+        # Broadcast a notice message
+        await space.broadcast("Event started", notice=True)
+
+        # Broadcast a file
+        file = File(path="mxc://...", filename="document.pdf", mimetype="application/pdf")
+        await space.broadcast(file=file)
+
+        # Broadcast an image
+        image = Image(path="mxc://...", filename="photo.jpg", mimetype="image/jpeg", width=800, height=600)
+        await space.broadcast(file=image)
+
+        # Broadcast a notice message to space's rooms and the rooms of its subspaces
+        await space.broadcast("New Announcement", notice=True, depth=2)
+        ```
+        """
+        rooms = filter(
+            lambda room: not isinstance(room, Space), self.get_children(depth=depth)
+        )
+        async_send = [
+            room.send(content, raw=raw, notice=notice, file=file) for room in rooms
+        ]
+        return await asyncio.gather(*async_send)

tests/test_bot.py

@@ -1,9 +1,11 @@
 import pytest
 
-from unittest.mock import AsyncMock, MagicMock, patch
-from nio import MatrixRoom, RoomMessageText, LoginError
+from unittest.mock import AsyncMock, MagicMock, Mock, patch
+from nio import MatrixRoom, RoomMessageText, LoginError, Event
 
 from matrix import Bot, Config, Extension, Room, Space
+from matrix.message import Message
+from matrix.types import File
 from matrix.errors import (
     CheckError,
     CommandNotFoundError,
@@ -970,3 +972,124 @@ async def task():
     job_names = [j.name for j in bot.scheduler.jobs]
 
     assert "task" in job_names
+
+
+@pytest.fixture
+def mock_send_response(bot):
+    """Set up client to return a mock event after room_send and fetch_event."""
+    send_response = Mock()
+    send_response.event_id = "$event123"
+    bot._client.room_send = AsyncMock(return_value=send_response)
+
+    mock_event = MagicMock(spec=Event)
+    mock_event.event_id = "$event123"
+
+    get_event_response = Mock()
+    get_event_response.event = mock_event
+    bot._client.room_get_event = AsyncMock(return_value=get_event_response)
+
+    return send_response
+
+
+@pytest.fixture
+def make_room(bot):
+    """Factory that creates a Room instance for a given room ID."""
+
+    def _make(room_id):
+        matrix_room = MatrixRoom(room_id=room_id, own_user_id="grace")
+        matrix_room.name = room_id
+        bot._client.rooms = {**bot._client.rooms, room_id: matrix_room}
+        return Room(matrix_room, bot.client)
+
+    return _make
+
+
+@pytest.mark.asyncio
+async def test_broadcast__expect_message_sent_to_all_rooms(
+    bot, make_room, mock_send_response
+):
+    room1 = make_room("!room1:example.com")
+    room2 = make_room("!room2:example.com")
+
+    results = await bot.broadcast([room1, room2], "Hello!")
+
+    assert len(results) == 2
+    assert all(isinstance(msg, Message) for msg in results)
+    assert bot._client.room_send.await_count == 2
+
+
+@pytest.mark.asyncio
+async def test_broadcast__with_empty_list__expect_no_messages(bot, mock_send_response):
+    results = await bot.broadcast([], "Hello!")
+
+    assert results == []
+    bot._client.room_send.assert_not_awaited()
+
+
+@pytest.mark.asyncio
+async def test_broadcast__with_space_in_list__expect_space_skipped(
+    bot, make_room, mock_send_response
+):
+    room = make_room("!room:example.com")
+    space_matrix = MatrixRoom(room_id="!space:example.com", own_user_id="grace")
+    space_matrix.name = "Test Space"
+    space_matrix.room_type = "m.space"
+    bot._client.rooms = {**bot._client.rooms, "!space:example.com": space_matrix}
+    space = Space(space_matrix, bot.client)
+
+    results = await bot.broadcast([room, space], "Hello!")
+
+    assert len(results) == 1
+    assert bot._client.room_send.await_count == 1
+    sent_room_ids = {
+        call.kwargs["room_id"] for call in bot._client.room_send.await_args_list
+    }
+    assert sent_room_ids == {"!room:example.com"}
+
+
+@pytest.mark.asyncio
+async def test_broadcast_raw__expect_unformatted_messages(
+    bot, make_room, mock_send_response
+):
+    room = make_room("!room:example.com")
+
+    await bot.broadcast([room], "Hello world!", raw=True)
+
+    call_args = bot._client.room_send.call_args
+    content = call_args.kwargs["content"]
+    assert content["msgtype"] == "m.text"
+    assert content["body"] == "Hello world!"
+    assert "formatted_body" not in content
+
+
+@pytest.mark.asyncio
+async def test_broadcast_notice__expect_notice_message_type(
+    bot, make_room, mock_send_response
+):
+    room = make_room("!room:example.com")
+
+    await bot.broadcast([room], "Special Event started!", notice=True)
+
+    call_args = bot._client.room_send.call_args
+    content = call_args.kwargs["content"]
+    assert content["msgtype"] == "m.notice"
+    assert content["body"] == "Special Event started!"
+
+
+@pytest.mark.asyncio
+async def test_broadcast_file__expect_file_message(bot, make_room, mock_send_response):
+    room = make_room("!room:example.com")
+
+    file = File(
+        path="mxc://example.com/abc123",
+        filename="document.pdf",
+        mimetype="application/pdf",
+    )
+
+    await bot.broadcast([room], file=file)
+
+    call_args = bot._client.room_send.call_args
+    content = call_args.kwargs["content"]
+    assert content["msgtype"] == "m.file"
+    assert content["body"] == "document.pdf"
+    assert content["url"] == "mxc://example.com/abc123"