From 08a15e5cdd4ff0ca8bc92b26fe79e00ac52dc48e Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Aleix=20Conchillo=20Flaqu=C3=A9?= Date: Tue, 28 May 2024 17:22:12 -0700 Subject: [PATCH] transports(daily): expose on_app_message --- CHANGELOG.md | 2 ++ src/pipecat/transports/services/daily.py | 5 +++++ 2 files changed, 7 insertions(+) diff --git a/CHANGELOG.md b/CHANGELOG.md index fcaae4cb3..b19c64876 100644 --- a/CHANGELOG.md +++ b/CHANGELOG.md @@ -9,6 +9,8 @@ and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0 ### Added +- Exposed Daily transport `on_app_message` event. + - Added Daily transport `on_call_state_updated` event. - Added Daily transport `start_recording()`, `stop_recording` and diff --git a/src/pipecat/transports/services/daily.py b/src/pipecat/transports/services/daily.py index 6d5006e9d..5491882f2 100644 --- a/src/pipecat/transports/services/daily.py +++ b/src/pipecat/transports/services/daily.py @@ -671,6 +671,7 @@ class DailyTransport(BaseTransport): # these handlers. self._register_event_handler("on_joined") self._register_event_handler("on_left") + self._register_event_handler("on_app_message") self._register_event_handler("on_call_state_updated") self._register_event_handler("on_dialout_connected") self._register_event_handler("on_dialout_stopped") @@ -752,6 +753,7 @@ class DailyTransport(BaseTransport): def _on_app_message(self, message: Any, sender: str): if self._input: self._input.push_app_message(message, sender) + self.on_app_message(message, sender) def _on_call_state_updated(self, state: str): self.on_call_state_updated(state) @@ -828,6 +830,9 @@ class DailyTransport(BaseTransport): def on_left(self): pass + def on_app_message(self, message, sender): + pass + def on_call_state_updated(self, state): pass