Merge pull request #3180 from pipecat-ai/aleix/deepgram-tts-service-fix
DeepgramTTSService: fix websocket header logging
This commit is contained in:
@@ -170,6 +170,11 @@ class DeepgramTTSService(WebsocketTTSService):
|
|||||||
|
|
||||||
self._websocket = await websocket_connect(url, additional_headers=headers)
|
self._websocket = await websocket_connect(url, additional_headers=headers)
|
||||||
|
|
||||||
|
headers = {
|
||||||
|
k: v for k, v in self._websocket.response.headers.items() if k.startswith("dg-")
|
||||||
|
}
|
||||||
|
logger.debug(f'{self}: Websocket connection initialized: {{"headers": {headers}}}')
|
||||||
|
|
||||||
await self._call_event_handler("on_connected")
|
await self._call_event_handler("on_connected")
|
||||||
except Exception as e:
|
except Exception as e:
|
||||||
logger.error(f"{self} exception: {e}")
|
logger.error(f"{self} exception: {e}")
|
||||||
@@ -280,14 +285,6 @@ class DeepgramTTSService(WebsocketTTSService):
|
|||||||
await self._connect()
|
await self._connect()
|
||||||
|
|
||||||
await self.start_ttfb_metrics()
|
await self.start_ttfb_metrics()
|
||||||
|
|
||||||
response = await self._deepgram_client.speak.asyncrest.v("1").stream_raw(
|
|
||||||
{"text": text}, options
|
|
||||||
)
|
|
||||||
|
|
||||||
headers = {k: v for k, v in response.headers.items() if k.startswith("dg-")}
|
|
||||||
logger.debug(f'{self}: HTTP connection initialized: {{"headers": {headers}}}')
|
|
||||||
|
|
||||||
await self.start_tts_usage_metrics(text)
|
await self.start_tts_usage_metrics(text)
|
||||||
|
|
||||||
yield TTSStartedFrame()
|
yield TTSStartedFrame()
|
||||||
|
|||||||
Reference in New Issue
Block a user