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

transport(daily): also accept TransportMessageFrame

Browse Source
This commit is contained in:
Aleix Conchillo Flaqué
2024-07-17 14:53:53 -07:00
parent 194790183a
commit 0a69a9e5ef
1 changed files with 7 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -198,14 +198,18 @@ class DailyTransportClient(EventHandler):
def set_callbacks(self, callbacks: DailyCallbacks): def set_callbacks(self, callbacks: DailyCallbacks):
self._callbacks = callbacks self._callbacks = callbacks
async def send_message(self, frame: DailyTransportMessageFrame): async def send_message(self, frame: TransportMessageFrame):
if not self._client: if not self._client:
return return
participant_id = None
if isinstance(frame, DailyTransportMessageFrame):
participant_id = frame.participant_id
future = self._loop.create_future() future = self._loop.create_future()
self._client.send_app_message( self._client.send_app_message(
frame.message, frame.message,
frame.participant_id, participant_id,
completion=completion_callback(future)) completion=completion_callback(future))
await future await future
@@ -655,7 +659,7 @@ class DailyOutputTransport(BaseOutputTransport):
await super().cleanup() await super().cleanup()
await self._client.cleanup() await self._client.cleanup()
async def send_message(self, frame: DailyTransportMessageFrame): async def send_message(self, frame: TransportMessageFrame):
await self._client.send_message(frame) await self._client.send_message(frame)
async def send_metrics(self, frame: MetricsFrame): async def send_metrics(self, frame: MetricsFrame):