From c55f67944d31d1898fb22f7e074470ac248e56ac Mon Sep 17 00:00:00 2001 From: pstruebi Date: Wed, 19 Mar 2025 12:51:24 +0100 Subject: [PATCH] refractoring --- src/auracast/multicast_client.py | 5 +++++ src/auracast/multicast_server.py | 2 +- 2 files changed, 6 insertions(+), 1 deletion(-) diff --git a/src/auracast/multicast_client.py b/src/auracast/multicast_client.py index 708874c..035f73f 100644 --- a/src/auracast/multicast_client.py +++ b/src/auracast/multicast_client.py @@ -1,5 +1,6 @@ import aiohttp import asyncio +import base64 from typing import Optional, Dict from auracast import auracast_config @@ -19,6 +20,10 @@ async def init(request_data : AuracastConfigGroup, base_url: Optional[str] = Non async def send_audio(data_dict: Dict[str, str], base_url: Optional[str] = None): + # TODO: use base64 encoding + for language, lc3_data in data_dict.items(): + data_dict[language] =lc3_data.decode('latin-1') + url = base_url if base_url is not None else BASE_URL async with aiohttp.ClientSession() as session: async with session.post(f"{url}/stream_lc3", json=data_dict) as response: diff --git a/src/auracast/multicast_server.py b/src/auracast/multicast_server.py index d63ed54..e24b4f0 100644 --- a/src/auracast/multicast_server.py +++ b/src/auracast/multicast_server.py @@ -54,7 +54,7 @@ async def send_audio(audio_data: dict[str, str]): for big in global_config_group.bigs: assert big.language in audio_data, HTTPException(status_code=500, detail='language len missmatch') log.info('Received a send audio request for %s', big.language) - big.audio_source = audio_data[big.language].encode('latin-1') + big.audio_source = audio_data[big.language].encode('latin-1') # TODO: use base64 encoding multicaster.big_conf = global_config_group.bigs multicaster.start_streaming()