From 9447b32f3e35b81940ece3d4874b846f4db71387 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Aleix=20Conchillo=20Flaqu=C3=A9?= Date: Wed, 15 May 2024 17:06:47 -0700 Subject: [PATCH] transports(daily): on_app_message doesn't need to be event handler --- src/pipecat/transports/services/daily.py | 10 +++++----- 1 file changed, 5 insertions(+), 5 deletions(-) diff --git a/src/pipecat/transports/services/daily.py b/src/pipecat/transports/services/daily.py index 820febc4e..714208139 100644 --- a/src/pipecat/transports/services/daily.py +++ b/src/pipecat/transports/services/daily.py @@ -594,7 +594,7 @@ class DailyTransport(BaseTransport): on_first_participant_joined=self._on_first_participant_joined, on_participant_joined=self._on_participant_joined, 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, ) self._params = params @@ -680,6 +680,10 @@ class DailyTransport(BaseTransport): def _on_first_participant_joined(self, 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): text = message["text"] timestamp = message["timestamp"] @@ -711,10 +715,6 @@ class DailyTransport(BaseTransport): def on_first_participant_joined(self, participant): 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 decorator(handler): self._add_event_handler(event_name, handler)