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

transports(daily): fix dialin-ready event handling

Browse Source
This commit is contained in:
Aleix Conchillo Flaqué
2024-05-23 14:32:49 -07:00
parent b1a622971b
commit 2a6183aba5
3 changed files with 12 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
src/pipecat/services/elevenlabs.py
View File

@@ -49,8 +49,8 @@ class ElevenLabsTTSService(TTSService):
async with self._aiohttp_session.post(url, json=payload, headers=headers, params=querystring) as r:
if r.status != 200:
logger.error(f"Audio fetch status code: {r.status}, error: {r.text}")
yield ErrorFrame(f"Audio fetch status code: {r.status}, error: {r.text}")
logger.error(f"Error getting audio (status: {r.status}, error: {r.text()})")
yield ErrorFrame(f"Error getting audio (status: {r.status}, error: {r.text()})")
return
async for chunk in r.content:

7
src/pipecat/transports/services/daily.py
View File

@@ -735,17 +735,18 @@ class DailyTransport(BaseTransport):
"Authorization": f"Bearer {self._params.api_key}",
"Content-Type": "application/x-www-form-urlencoded"
}
querystring = {
data = {
"callId": self._params.dialin_settings.call_id,
"callDomain": self._params.dialin_settings.call_domain,
"sipUri": sip_endpoint
}
url = f"{self._params.api_url}/dialin/pinlessCallUpdate"
async with session.post(url, headers=headers, params=querystring) as r:
async with session.post(url, headers=headers, data=data) as r:
if r.status != 200:
logger.error(
f"Unable to handle dialin-ready event (status: {r.status}, error: {r.text})")
f"Unable to handle dialin-ready event (status: {r.status}, error: {r.text()})")
return
logger.debug("dialin-ready event handled successfully")