|
1
|
|
|
import asyncio |
|
2
|
|
|
from asyncio.events import get_event_loop |
|
3
|
|
|
from datetime import datetime, timezone |
|
4
|
|
|
import pytest |
|
5
|
|
|
from unittest.mock import Mock |
|
6
|
|
|
|
|
7
|
|
|
from gadgets.media_player import MediaPlayer |
|
8
|
|
|
|
|
9
|
|
|
from races_for_testing import get_test_race |
|
10
|
|
|
from users_for_testing import get_test_entrant, get_test_entrants |
|
11
|
|
|
|
|
12
|
|
|
|
|
13
|
|
|
@pytest.mark.asyncio |
|
14
|
|
|
async def test_entrant_finished_first(random_users): |
|
15
|
|
|
event_loop = get_event_loop() |
|
16
|
|
|
event_loop.set_debug(True) |
|
17
|
|
|
play_media = Mock() |
|
18
|
|
|
media_player = MediaPlayer() |
|
19
|
|
|
media_file_path = "fake/path/test.mp3" |
|
20
|
|
|
media_player.play_media_callback = play_media |
|
21
|
|
|
media_player.add_trigger(media_file_path, 1) |
|
22
|
|
|
media_player.monitoring_type = 0 |
|
23
|
|
|
await asyncio.sleep(0.1) |
|
24
|
|
|
assert len(media_player.triggers) == 1 |
|
25
|
|
|
play_media.assert_not_called() |
|
26
|
|
|
entrant = get_test_entrant( |
|
27
|
|
|
status_value="in_progress", user=next(random_users)) |
|
28
|
|
|
entrants = get_test_entrants(random_users, entrant) |
|
29
|
|
|
race = get_test_race(entrants=entrants) |
|
30
|
|
|
media_player.race_updated(race, entrant.user.full_name) |
|
31
|
|
|
await asyncio.sleep(0.1) |
|
32
|
|
|
play_media.assert_not_called() |
|
33
|
|
|
entrant = race.get_entrant_by_name(entrant.user.full_name) |
|
34
|
|
|
await asyncio.sleep(0.1) |
|
35
|
|
|
entrant.place = 1 |
|
36
|
|
|
entrant.status.value = "finished" |
|
37
|
|
|
entrant.finish_time = datetime.now(timezone.utc) |
|
38
|
|
|
media_player.race_updated(race, entrant.user.full_name) |
|
39
|
|
|
await asyncio.sleep(0.1) |
|
40
|
|
|
play_media.assert_called_once_with( |
|
41
|
|
|
media_file_path, 0) |
|
42
|
|
|
|
ssbm-oro /
racetime-obs
