diff --git a/code/wbstream_poc_datachannel.py b/code/wbstream_poc_datachannel.py index 2850294..fd6ef0b 100755 --- a/code/wbstream_poc_datachannel.py +++ b/code/wbstream_poc_datachannel.py @@ -16,6 +16,7 @@ logging.getLogger("livekit").setLevel(logging.WARNING) API_BASE = "https://stream.wb.ru" WS_URL = "wss://rtc-el-01.wb.ru" +HARDCODED_ROOM_ID = "019e23c2-a580-7550-b08a-7ac5342ca21f" TEST_MESSAGES = ["Hello WB Stream!", "Hello world", "X" * 100, "Final test"] def _get_room_token(room_id: str, display_name: str) -> tuple[str, str]: @@ -48,11 +49,11 @@ async def run_poc() -> dict: results = {"server_ok": False, "client_ok": False, "sent": 0, "recv": 0, "errors": []} server, client = rtc.Room(), rtc.Room() - shared_room_id, _ = _get_room_token("", "OlcRTC-Server") + shared_room_id = HARDCODED_ROOM_ID print("[1/3] Connecting Server & Client...") try: - shared_room_id, server_tok = _get_room_token("", "OlcRTC-Server") + shared_room_id, server_tok = _get_room_token(shared_room_id, "OlcRTC-Server") _, client_tok = _get_room_token(shared_room_id, "OlcRTC-Client") @server.on("data_received") diff --git a/code/wbstream_poc_videochannel.py b/code/wbstream_poc_videochannel.py index 51b7e6d..5f0326d 100755 --- a/code/wbstream_poc_videochannel.py +++ b/code/wbstream_poc_videochannel.py @@ -18,6 +18,7 @@ logging.getLogger("livekit").setLevel(logging.WARNING) API_BASE = "https://stream.wb.ru" WS_URL = "wss://wbstream01-el.wb.ru:7880" +HARDCODED_ROOM_ID = "019e23c2-a580-7550-b08a-7ac5342ca21f" FPS = 10 TEST_MESSAGES = ["Hello WB Stream via Video!", "Packed JSON payload test.", "X" * 200, "Final VideoChannel test"] @@ -72,7 +73,7 @@ async def run_poc() -> dict: print("[1/3] Connecting peers...") try: - shared_room_id, server_tok = _get_room_token("", "OlcRTC-Server") + shared_room_id, server_tok = _get_room_token(HARDCODED_ROOM_ID, "OlcRTC-Server") _, client_tok = _get_room_token(shared_room_id, "OlcRTC-Client") async def process_video_stream(stream: rtc.VideoStream):