Merge pull request #1439 from pipecat-ai/mb/fix-rtvi-bot-speaking-events

Fix: RTVIObserver now outputs a single bot started and stopped speaki…

CHANGELOG.md

@@ -13,6 +13,9 @@ and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0
 
 ### Fixed
 
+- Fixed an issue where the `RTVIObserver` would report two bot started and
+  stopped speaking events for each bot turn.
+
 - Fixed an issue in `UltravoxSTTService` that caused improper audio processing
   and incorrect LLM frame output.
 

src/pipecat/processors/frameworks/rtvi.py

@@ -440,7 +440,9 @@ class RTVIObserver(BaseObserver):
 
         if isinstance(frame, (UserStartedSpeakingFrame, UserStoppedSpeakingFrame)):
             await self._handle_interruptions(frame)
-        elif isinstance(frame, (BotStartedSpeakingFrame, BotStoppedSpeakingFrame)):
+        elif isinstance(frame, (BotStartedSpeakingFrame, BotStoppedSpeakingFrame)) and (
+            direction == FrameDirection.UPSTREAM
+        ):
             await self._handle_bot_speaking(frame)
         elif isinstance(frame, (TranscriptionFrame, InterimTranscriptionFrame)):
             await self._handle_user_transcriptions(frame)