refractoring

This commit is contained in:
2025-03-19 12:51:24 +01:00
parent 5932915f23
commit c55f67944d
2 changed files with 6 additions and 1 deletions
+5
View File
@@ -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:
+1 -1
View File
@@ -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()