auracaster/auracast-translator
3
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

bugfixes

Browse Source
This commit is contained in:
pstruebi
2025-03-17 13:45:58 +01:00
parent 88da77d2d4
commit fcb85972f4
1 changed files with 2 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
src/multilang_translator/translator_server/translator_server.py
View File

@@ -37,12 +37,11 @@ def init_endpoint(endpoint: Endpoint, languages: list[str]):
log.info(f"Initializing endpoint: {endpoint.name} at {endpoint.url}") log.info(f"Initializing endpoint: {endpoint.name} at {endpoint.url}")
# Create a config for this endpoint # Create a config for this endpoint
config = multicast_client.AuracastConfigGroup( config = auracast_config.AuracastConfigGroup(
bigs=[getattr(auracast_config, f"AuracastBigConfig{lang.capitalize()}")() bigs=[getattr(auracast_config, f"AuracastBigConfig{lang.capitalize()}")()
for lang in languages] for lang in languages]
) )
# some default configs (for now)
# Configure the transport # Configure the transport
config.transport = 'auto' 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 # 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): 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 CURRENT_ENDPOINT_CONFIG[endpoint.id] = config
else: else:
log.info('Endpoint %s was already initialized', endpoint.name) 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) # Add to audio data dictionary (decode bytes to string for JSON serialization)
# Start the monitoring coroutine to wait for streaming to complete # Start the monitoring coroutine to wait for streaming to complete
# This will set the state to COMPLETED when finished # This will set the state to COMPLETED when finished
asyncio.create_task(monitor_streaming_completion(ep_group)) asyncio.create_task(monitor_streaming_completion(ep_group))