wx44wx/pipecat
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

transports(base_output): push bot started/stopped frames downstream

Browse Source
This commit is contained in:
Aleix Conchillo Flaqué
2024-11-06 11:34:52 -08:00
parent 2eccb33e73
commit 6d8b885071
1 changed files with 3 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
src/pipecat/transports/base_output.py
View File

@@ -208,12 +208,14 @@ class BaseOutputTransport(FrameProcessor):
async def _bot_started_speaking(self): async def _bot_started_speaking(self):
if not self._bot_speaking: if not self._bot_speaking:
logger.debug("Bot started speaking") logger.debug("Bot started speaking")
await self.push_frame(BotStartedSpeakingFrame())
await self.push_frame(BotStartedSpeakingFrame(), FrameDirection.UPSTREAM) await self.push_frame(BotStartedSpeakingFrame(), FrameDirection.UPSTREAM)
self._bot_speaking = True self._bot_speaking = True
async def _bot_stopped_speaking(self): async def _bot_stopped_speaking(self):
if self._bot_speaking: if self._bot_speaking:
logger.debug("Bot stopped speaking") logger.debug("Bot stopped speaking")
await self.push_frame(BotStoppedSpeakingFrame())
await self.push_frame(BotStoppedSpeakingFrame(), FrameDirection.UPSTREAM) await self.push_frame(BotStoppedSpeakingFrame(), FrameDirection.UPSTREAM)
self._bot_speaking = False self._bot_speaking = False
@@ -452,6 +454,7 @@ class BaseOutputTransport(FrameProcessor):
# it's actually speaking. # it's actually speaking.
if isinstance(frame, TTSAudioRawFrame): if isinstance(frame, TTSAudioRawFrame):
await self._bot_started_speaking() await self._bot_started_speaking()
await self.push_frame(BotSpeakingFrame())
await self.push_frame(BotSpeakingFrame(), FrameDirection.UPSTREAM) await self.push_frame(BotSpeakingFrame(), FrameDirection.UPSTREAM)
# Also, push frame downstream in case anyone else needs it. # Also, push frame downstream in case anyone else needs it.