PowerOn/gateway
2
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

fixed route to media center

Browse source
This commit is contained in:
patrick-motsch 2026-02-13 13:12:21 +01:00
parent 9226c42760
commit fa530bfd4c
1 changed files with 26 additions and 21 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

41
modules/features/teamsbot/routeFeatureTeamsbot.py
View file

@ -362,26 +362,31 @@ async def bridgeStatusCallback(
logger.info(f"Bridge status callback: session={sessionId}, status={status}") logger.info(f"Bridge status callback: session={sessionId}, status={status}")
# Update session status try:
from modules.datamodels.datamodelUam import User # Update session status (bridge callbacks have no user context)
systemUser = User(id="system", email="system@internal") from modules.datamodels.datamodelUam import User
interface = interfaceDb.getInterface(systemUser, featureInstanceId=instanceId) systemUser = User(id="system", username="system", email="system@internal")
interface = interfaceDb.getInterface(systemUser, featureInstanceId=instanceId)
updates = {"status": status} updates = {"status": status}
if errorMessage: if errorMessage:
updates["errorMessage"] = errorMessage updates["errorMessage"] = errorMessage
if status == TeamsbotSessionStatus.ACTIVE.value: if status == TeamsbotSessionStatus.ACTIVE.value:
from modules.shared.timeUtils import getUtcTimestamp from modules.shared.timeUtils import getUtcTimestamp
updates["startedAt"] = getUtcTimestamp() updates["startedAt"] = getUtcTimestamp()
elif status in [TeamsbotSessionStatus.ENDED.value, TeamsbotSessionStatus.ERROR.value]: elif status in [TeamsbotSessionStatus.ENDED.value, TeamsbotSessionStatus.ERROR.value]:
from modules.shared.timeUtils import getUtcTimestamp from modules.shared.timeUtils import getUtcTimestamp
updates["endedAt"] = getUtcTimestamp() updates["endedAt"] = getUtcTimestamp()
interface.updateSession(sessionId, updates) interface.updateSession(sessionId, updates)
# Emit SSE event # Emit SSE event
from .service import _emitSessionEvent from .service import _emitSessionEvent
await _emitSessionEvent(sessionId, "statusChange", {"status": status, "errorMessage": errorMessage}) await _emitSessionEvent(sessionId, "statusChange", {"status": status, "errorMessage": errorMessage})
except Exception as e:
logger.error(f"Bridge status callback processing failed: session={sessionId}, error={e}")
# Still return 200 so the bridge doesn't retry endlessly
return {"received": True} return {"received": True}
@ -405,7 +410,7 @@ async def bridgeAudioWebsocket(
config = _getInstanceConfig(instanceId) config = _getInstanceConfig(instanceId)
from modules.datamodels.datamodelUam import User from modules.datamodels.datamodelUam import User
systemUser = User(id="system", email="system@internal") systemUser = User(id="system", username="system", email="system@internal")
service = TeamsbotService(systemUser, None, instanceId, config) service = TeamsbotService(systemUser, None, instanceId, config)
try: try: