You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
108 lines
3.7 KiB
108 lines
3.7 KiB
#!/usr/bin/env python3
|
|
import asyncio
|
|
import unittest
|
|
from unittest.mock import Mock, MagicMock, patch
|
|
import json
|
|
# for aiortc and its dependencies
|
|
import warnings
|
|
warnings.filterwarnings("ignore", category=DeprecationWarning)
|
|
|
|
from aiortc import RTCDataChannel
|
|
from aiortc.mediastreams import VIDEO_CLOCK_RATE, VIDEO_TIME_BASE
|
|
import capnp
|
|
import pyaudio
|
|
|
|
from cereal import messaging, log
|
|
|
|
from openpilot.system.webrtc.webrtcd import CerealOutgoingMessageProxy, CerealIncomingMessageProxy
|
|
from openpilot.system.webrtc.device.video import LiveStreamVideoStreamTrack
|
|
from openpilot.system.webrtc.device.audio import AudioInputStreamTrack
|
|
from openpilot.common.realtime import DT_DMON
|
|
|
|
|
|
class TestStreamSession(unittest.TestCase):
|
|
def setUp(self):
|
|
self.loop = asyncio.new_event_loop()
|
|
|
|
def tearDown(self):
|
|
self.loop.stop()
|
|
self.loop.close()
|
|
|
|
def test_outgoing_proxy(self):
|
|
test_msg = log.Event.new_message()
|
|
test_msg.logMonoTime = 123
|
|
test_msg.valid = True
|
|
test_msg.customReservedRawData0 = b"test"
|
|
expected_dict = {"type": "customReservedRawData0", "logMonoTime": 123, "valid": True, "data": "test"}
|
|
expected_json = json.dumps(expected_dict).encode()
|
|
|
|
channel = Mock(spec=RTCDataChannel)
|
|
mocked_submaster = messaging.SubMaster(["customReservedRawData0"])
|
|
def mocked_update(t):
|
|
mocked_submaster.update_msgs(0, [test_msg])
|
|
|
|
with patch.object(messaging.SubMaster, "update", side_effect=mocked_update):
|
|
proxy = CerealOutgoingMessageProxy(mocked_submaster)
|
|
proxy.add_channel(channel)
|
|
|
|
proxy.update()
|
|
|
|
channel.send.assert_called_once_with(expected_json)
|
|
|
|
def test_incoming_proxy(self):
|
|
tested_msgs = [
|
|
{"type": "customReservedRawData0", "data": "test"}, # primitive
|
|
{"type": "can", "data": [{"address": 0, "busTime": 0, "dat": "", "src": 0}]}, # list
|
|
{"type": "testJoystick", "data": {"axes": [0, 0], "buttons": [False]}}, # dict
|
|
]
|
|
|
|
mocked_pubmaster = MagicMock(spec=messaging.PubMaster)
|
|
|
|
proxy = CerealIncomingMessageProxy(mocked_pubmaster)
|
|
|
|
for msg in tested_msgs:
|
|
proxy.send(json.dumps(msg).encode())
|
|
|
|
mocked_pubmaster.send.assert_called_once()
|
|
mt, md = mocked_pubmaster.send.call_args.args
|
|
self.assertEqual(mt, msg["type"])
|
|
self.assertIsInstance(md, capnp._DynamicStructBuilder)
|
|
self.assertTrue(hasattr(md, msg["type"]))
|
|
|
|
mocked_pubmaster.reset_mock()
|
|
|
|
def test_livestream_track(self):
|
|
fake_msg = messaging.new_message("livestreamDriverEncodeData")
|
|
|
|
config = {"receive.return_value": fake_msg.to_bytes()}
|
|
with patch("cereal.messaging.SubSocket", spec=True, **config):
|
|
track = LiveStreamVideoStreamTrack("driver")
|
|
|
|
self.assertTrue(track.id.startswith("driver"))
|
|
self.assertEqual(track.codec_preference(), "H264")
|
|
|
|
for i in range(5):
|
|
packet = self.loop.run_until_complete(track.recv())
|
|
self.assertEqual(packet.time_base, VIDEO_TIME_BASE)
|
|
self.assertEqual(packet.pts, int(i * DT_DMON * VIDEO_CLOCK_RATE))
|
|
self.assertEqual(packet.size, 0)
|
|
|
|
def test_input_audio_track(self):
|
|
packet_time, rate = 0.02, 16000
|
|
sample_count = int(packet_time * rate)
|
|
mocked_stream = MagicMock(spec=pyaudio.Stream)
|
|
mocked_stream.read.return_value = b"\x00" * 2 * sample_count
|
|
|
|
config = {"open.side_effect": lambda *args, **kwargs: mocked_stream}
|
|
with patch("pyaudio.PyAudio", spec=True, **config):
|
|
track = AudioInputStreamTrack(audio_format=pyaudio.paInt16, packet_time=packet_time, rate=rate)
|
|
|
|
for i in range(5):
|
|
frame = self.loop.run_until_complete(track.recv())
|
|
self.assertEqual(frame.rate, rate)
|
|
self.assertEqual(frame.samples, sample_count)
|
|
self.assertEqual(frame.pts, i * sample_count)
|
|
|
|
|
|
if __name__ == "__main__":
|
|
unittest.main()
|
|
|