Merge pull request #97 from valueonag/feat/auxiliaries2

test websocket
This commit is contained in:
Patrick Motsch 2026-02-13 13:37:01 +01:00 committed by GitHub
commit 0c49523e38
No known key found for this signature in database
GPG key ID: B5690EEEBB952194

View file

@ -403,21 +403,23 @@ async def bridgeAudioWebsocket(
Gateway sends: TTS audio responses
"""
await websocket.accept()
logger.info(f"Bridge audio WebSocket connected: session={sessionId}")
logger.info(f"Bridge audio WebSocket connected: session={sessionId}, instance={instanceId}")
# TODO: Validate bridge API key from headers/query params
config = _getInstanceConfig(instanceId)
from modules.datamodels.datamodelUam import User
systemUser = User(id="system", username="system", email="system@internal")
service = TeamsbotService(systemUser, None, instanceId, config)
try:
config = _getInstanceConfig(instanceId)
logger.info(f"Bridge audio WebSocket config loaded: session={sessionId}")
from modules.datamodels.datamodelUam import User
systemUser = User(id="system", username="system", email="system@internal")
service = TeamsbotService(systemUser, None, instanceId, config)
logger.info(f"Bridge audio WebSocket service created: session={sessionId}")
await service.handleAudioStream(websocket, sessionId)
except WebSocketDisconnect:
logger.info(f"Bridge audio WebSocket disconnected: session={sessionId}")
except Exception as e:
logger.error(f"Bridge audio WebSocket error: session={sessionId}, error={e}")
logger.error(f"Bridge audio WebSocket error: session={sessionId}, error={e}", exc_info=True)
finally:
logger.info(f"Bridge audio WebSocket closed: session={sessionId}")