From 7c13663a4eb933a519a463c35ac9f112fd0b48c7 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Aleix=20Conchillo=20Flaqu=C3=A9?= Date: Thu, 20 Jun 2024 13:01:25 -0700 Subject: [PATCH] transports(daily): added dialout_answered event --- CHANGELOG.md | 3 +++ src/pipecat/transports/services/daily.py | 9 +++++++++ 2 files changed, 12 insertions(+) diff --git a/CHANGELOG.md b/CHANGELOG.md index 6b89d51a1..6afe42d1c 100644 --- a/CHANGELOG.md +++ b/CHANGELOG.md @@ -9,6 +9,9 @@ and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0 ### Added +- Added Daily transport event: `on_dialout_answered`. See + https://reference-python.daily.co/api_reference.html#daily.EventHandler + - Added new `AzureSTTService`. This allows you to use Azure Speech-To-Text. ### Other diff --git a/src/pipecat/transports/services/daily.py b/src/pipecat/transports/services/daily.py index b0a9d8f8e..2476fc8e6 100644 --- a/src/pipecat/transports/services/daily.py +++ b/src/pipecat/transports/services/daily.py @@ -114,6 +114,7 @@ class DailyCallbacks(BaseModel): on_app_message: Callable[[Any, str], None] on_call_state_updated: Callable[[str], None] on_dialin_ready: Callable[[str], None] + on_dialout_answered: Callable[[Any], None] on_dialout_connected: Callable[[Any], None] on_dialout_stopped: Callable[[Any], None] on_dialout_error: Callable[[Any], None] @@ -407,6 +408,9 @@ class DailyTransportClient(EventHandler): def on_dialin_ready(self, sip_endpoint: str): self._callbacks.on_dialin_ready(sip_endpoint) + def on_dialout_answered(self, data: Any): + self._callbacks.on_dialout_answered(data) + def on_dialout_connected(self, data: Any): self._callbacks.on_dialout_connected(data) @@ -674,6 +678,7 @@ class DailyTransport(BaseTransport): on_app_message=self._on_app_message, on_call_state_updated=self._on_call_state_updated, on_dialin_ready=self._on_dialin_ready, + on_dialout_answered=self._on_dialout_answered, on_dialout_connected=self._on_dialout_connected, on_dialout_stopped=self._on_dialout_stopped, on_dialout_error=self._on_dialout_error, @@ -696,6 +701,7 @@ class DailyTransport(BaseTransport): self._register_event_handler("on_app_message") self._register_event_handler("on_call_state_updated") self._register_event_handler("on_dialin_ready") + self._register_event_handler("on_dialout_answered") self._register_event_handler("on_dialout_connected") self._register_event_handler("on_dialout_stopped") self._register_event_handler("on_dialout_error") @@ -823,6 +829,9 @@ class DailyTransport(BaseTransport): asyncio.run_coroutine_threadsafe(self._handle_dialin_ready(sip_endpoint), self._loop) self._call_async_event_handler("on_dialin_ready", sip_endpoint) + def _on_dialout_answered(self, data): + self._call_async_event_handler("on_dialout_answered", data) + def _on_dialout_connected(self, data): self._call_async_event_handler("on_dialout_connected", data)