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

Code review fixes

Browse Source
This commit is contained in:
Mark Backman
2025-04-16 22:29:33 -04:00
parent 1e0a9d7b06
commit 2dafbee2aa
1 changed files with 9 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

16
src/pipecat/services/elevenlabs/tts.py
View File

@@ -523,21 +523,24 @@ class ElevenLabsHttpTTSService(WordTTSService):
def _set_voice_settings(self): def _set_voice_settings(self):
return build_elevenlabs_voice_settings(self._settings) return build_elevenlabs_voice_settings(self._settings)
def _reset_state(self):
"""Reset internal state variables."""
self._cumulative_time = 0
self._started = False
self._previous_text = ""
logger.debug(f"{self}: Reset internal state")
async def start(self, frame: StartFrame): async def start(self, frame: StartFrame):
"""Initialize the service upon receiving a StartFrame.""" """Initialize the service upon receiving a StartFrame."""
await super().start(frame) await super().start(frame)
self._output_format = output_format_from_sample_rate(self.sample_rate) self._output_format = output_format_from_sample_rate(self.sample_rate)
self._cumulative_time = 0 self._reset_state()
self._started = False
self._previous_text = ""
async def push_frame(self, frame: Frame, direction: FrameDirection = FrameDirection.DOWNSTREAM): async def push_frame(self, frame: Frame, direction: FrameDirection = FrameDirection.DOWNSTREAM):
await super().push_frame(frame, direction) await super().push_frame(frame, direction)
if isinstance(frame, (StartInterruptionFrame, TTSStoppedFrame)): if isinstance(frame, (StartInterruptionFrame, TTSStoppedFrame)):
# Reset timing on interruption or stop # Reset timing on interruption or stop
self._started = False self._reset_state()
self._cumulative_time = 0
self._previous_text = ""
if isinstance(frame, TTSStoppedFrame): if isinstance(frame, TTSStoppedFrame):
await self.add_word_timestamps([("LLMFullResponseEndFrame", 0), ("Reset", 0)]) await self.add_word_timestamps([("LLMFullResponseEndFrame", 0), ("Reset", 0)])
@@ -631,7 +634,6 @@ class ElevenLabsHttpTTSService(WordTTSService):
# Include previous text as context if available # Include previous text as context if available
if self._previous_text: if self._previous_text:
payload["previous_text"] = self._previous_text payload["previous_text"] = self._previous_text
print(f"Previous text: {self._previous_text}")
if self._voice_settings: if self._voice_settings:
payload["voice_settings"] = self._voice_settings payload["voice_settings"] = self._voice_settings