diff --git a/src/multilang_translator/translator_server/translator_server.py b/src/multilang_translator/translator_server/translator_server.py index 7b4b467..6dab81d 100644 --- a/src/multilang_translator/translator_server/translator_server.py +++ b/src/multilang_translator/translator_server/translator_server.py @@ -37,12 +37,11 @@ def init_endpoint(endpoint: Endpoint, languages: list[str]): log.info(f"Initializing endpoint: {endpoint.name} at {endpoint.url}") # Create a config for this endpoint - config = multicast_client.AuracastConfigGroup( + config = auracast_config.AuracastConfigGroup( bigs=[getattr(auracast_config, f"AuracastBigConfig{lang.capitalize()}")() for lang in languages] ) - # some default configs (for now) # Configure the transport config.transport = 'auto' @@ -52,7 +51,7 @@ def init_endpoint(endpoint: Endpoint, languages: list[str]): # Initialize the endpoint if config changed or if it's not already initialized if not multicast_client.get_status(base_url=endpoint.url)['is_initialized'] or config != CURRENT_ENDPOINT_CONFIG.get(endpoint.id): - multicast_client.request_init(config, base_url=endpoint.url) + multicast_client.init(config, base_url=endpoint.url) CURRENT_ENDPOINT_CONFIG[endpoint.id] = config else: log.info('Endpoint %s was already initialized', endpoint.name) @@ -127,7 +126,6 @@ async def make_announcement(text: str, ep_group: EndpointGroup): # Add to audio data dictionary (decode bytes to string for JSON serialization) - # Start the monitoring coroutine to wait for streaming to complete # This will set the state to COMPLETED when finished asyncio.create_task(monitor_streaming_completion(ep_group))