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

transports(daily): on_app_message doesn't need to be event handler

Browse Source
This commit is contained in:
Aleix Conchillo Flaqué
2024-05-15 17:06:47 -07:00
parent af10adb7fe
commit f9919e6917
1 changed files with 5 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -594,7 +594,7 @@ class DailyTransport(BaseTransport):
on_first_participant_joined=self._on_first_participant_joined, on_first_participant_joined=self._on_first_participant_joined,
on_participant_joined=self._on_participant_joined, on_participant_joined=self._on_participant_joined,
on_participant_left=self._on_participant_left, on_participant_left=self._on_participant_left,
on_app_message=self.on_app_message, on_app_message=self._on_app_message,
on_error=self._on_error, on_error=self._on_error,
) )
self._params = params self._params = params
@@ -680,6 +680,10 @@ class DailyTransport(BaseTransport):
def _on_first_participant_joined(self, participant): def _on_first_participant_joined(self, participant):
self.on_first_participant_joined(participant) self.on_first_participant_joined(participant)
def _on_app_message(self, message: Any, sender: str):
if self._input:
self._input.push_app_message(message, sender)
def _on_transcription_message(self, participant_id, message): def _on_transcription_message(self, participant_id, message):
text = message["text"] text = message["text"]
timestamp = message["timestamp"] timestamp = message["timestamp"]
@@ -711,10 +715,6 @@ class DailyTransport(BaseTransport):
def on_first_participant_joined(self, participant): def on_first_participant_joined(self, participant):
pass pass
def on_app_message(self, message: Any, sender: str):
if self._input:
self._input.push_app_message(message, sender)
def event_handler(self, event_name: str): def event_handler(self, event_name: str):
def decorator(handler): def decorator(handler):
self._add_event_handler(event_name, handler) self._add_event_handler(event_name, handler)