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

revert most of the changes except keyword naming fix

Browse Source
This commit is contained in:
Severin Klingler
2025-05-21 09:24:03 +02:00
parent e1299d59bf
commit e74b900914
1 changed files with 2 additions and 15 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -276,16 +276,8 @@ class ElevenLabsTTSService(AudioContextWordTTSService):
async def flush_audio(self): async def flush_audio(self):
if self._websocket and self._context_id: if self._websocket and self._context_id:
self._context_id_to_close = self._context_id msg = {"context_id": self._context_id, "flush": True}
msg = {"context_id": self._context_id, "flush": True, "xi_api_key": self._api_key}
await self._websocket.send(json.dumps(msg)) await self._websocket.send(json.dumps(msg))
msg = {
"context_id": self._context_id,
"close_context": True,
"xi_api_key": self._api_key,
}
await self._websocket.send(json.dumps(msg))
self._context_id = None
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)
@@ -417,14 +409,9 @@ class ElevenLabsTTSService(AudioContextWordTTSService):
if msg.get("isFinal"): if msg.get("isFinal"):
logger.trace(f"Received final message for context {received_ctx_id}") logger.trace(f"Received final message for context {received_ctx_id}")
# Context has finished # Context has finished
if ( if self._context_id == received_ctx_id:
self._context_id == received_ctx_id
or self._context_id_to_close == received_ctx_id
):
self._context_id = None self._context_id = None
self._context_id_to_close = None
self._started = False self._started = False
await self.push_frame(TTSStoppedFrame())
async def _keepalive_task_handler(self): async def _keepalive_task_handler(self):
while True: while True: