Expand source code
@functools.cache
def create_mock_room() -> Any:
MockRoom = create_autospec(rtc.Room, instance=True)
MockRoom.local_participant = create_autospec(rtc.LocalParticipant, instance=True)
MockRoom._info = create_autospec(rtc.room.proto_room.RoomInfo, instance=True) # type: ignore
MockRoom.isconnected.return_value = True
MockRoom.name = "mock_room"
MockRoom.metadata = ""
MockRoom.num_participants = 2
MockRoom.num_publishers = 2
MockRoom.connection_state = rtc.ConnectionState.CONN_CONNECTED
MockRoom.departure_timeout = 0
MockRoom.empty_timeout = 0
MockRoom.sid = AsyncMock(return_value="RM_mock_sid")
mock_remote_participant = create_autospec(rtc.RemoteParticipant, instance=True)
mock_remote_participant.identity = "mock_user"
mock_remote_participant.sid = "PA_mock_user"
mock_remote_participant.kind = rtc.ParticipantKind.PARTICIPANT_KIND_STANDARD
MockRoom.remote_participants = {mock_remote_participant.sid: mock_remote_participant}
return MockRoom