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

Teamsbot: start new transcript block after 5s pause even for same speaker

Browse source 
Made-with: Cursor
This commit is contained in:
patrick-motsch 2026-02-27 23:48:47 +01:00
parent a527806436
commit b9c3ad38fb
1 changed files with 7 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

8
modules/features/teamsbot/service.py
View file

@ -87,6 +87,7 @@ class TeamsbotService:
self._lastTranscriptSpeaker: Optional[str] = None self._lastTranscriptSpeaker: Optional[str] = None
self._lastTranscriptText: Optional[str] = None self._lastTranscriptText: Optional[str] = None
self._lastTranscriptId: Optional[str] = None self._lastTranscriptId: Optional[str] = None
self._lastSttTime: float = 0.0
self._lastBotResponseText: Optional[str] = None self._lastBotResponseText: Optional[str] = None
self._lastBotResponseTs: float = 0.0 self._lastBotResponseTs: float = 0.0
@ -623,12 +624,14 @@ class TeamsbotService:
# Differential transcript writing: # Differential transcript writing:
# audioCapture from same speaker → append text (merge STT chunks into one block) # audioCapture from same speaker → append text (merge STT chunks into one block)
# other sources → always create a new record # Start a new block after a pause (>5s gap between STT results)
sttPauseThreshold = 5.0
isMerge = ( isMerge = (
source == "audioCapture" source == "audioCapture"
and self._lastTranscriptSpeaker == speaker and self._lastTranscriptSpeaker == speaker
and self._lastTranscriptText is not None and self._lastTranscriptText is not None
and self._lastTranscriptId is not None and self._lastTranscriptId is not None
and (time.time() - self._lastSttTime) < sttPauseThreshold
) )
if isMerge: if isMerge:
@ -680,6 +683,9 @@ class TeamsbotService:
count = session.get("transcriptSegmentCount", 0) + 1 count = session.get("transcriptSegmentCount", 0) + 1
interface.updateSession(sessionId, {"transcriptSegmentCount": count}) interface.updateSession(sessionId, {"transcriptSegmentCount": count})
if source == "audioCapture":
self._lastSttTime = time.time()
displayText = self._lastTranscriptText if isMerge else text displayText = self._lastTranscriptText if isMerge else text
await _emitSessionEvent(sessionId, "transcript", { await _emitSessionEvent(sessionId, "transcript", {
"id": createdTranscript.get("id"), "id": createdTranscript.get("id"),