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

transport(daily): add dialin-ready event

Browse Source
This commit is contained in:
Aleix Conchillo Flaqué
2024-05-23 07:12:31 -07:00
parent 3768cb2f2c
commit 8d7d1a7e24
1 changed files with 12 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -105,6 +105,7 @@ class DailyCallbacks(BaseModel):
on_left: Callable[[], None] on_left: Callable[[], None]
on_error: Callable[[str], None] on_error: Callable[[str], None]
on_app_message: Callable[[Any, str], None] on_app_message: Callable[[Any, str], None]
on_dialin_ready: Callable[[str], None]
on_dialout_connected: Callable[[Any], None] on_dialout_connected: Callable[[Any], None]
on_dialout_stopped: Callable[[Any], None] on_dialout_stopped: Callable[[Any], None]
on_dialout_error: Callable[[Any], None] on_dialout_error: Callable[[Any], None]
@@ -371,6 +372,9 @@ class DailyTransportClient(EventHandler):
def on_app_message(self, message: Any, sender: str): def on_app_message(self, message: Any, sender: str):
self._callbacks.on_app_message(message, sender) self._callbacks.on_app_message(message, sender)
def on_dialin_ready(self, sip_endpoint: str):
self._callbacks.on_dialin_ready(sip_endpoint)
def on_dialout_connected(self, data: Any): def on_dialout_connected(self, data: Any):
self._callbacks.on_dialout_connected(data) self._callbacks.on_dialout_connected(data)
@@ -622,6 +626,7 @@ class DailyTransport(BaseTransport):
on_left=self._on_left, on_left=self._on_left,
on_error=self._on_error, on_error=self._on_error,
on_app_message=self._on_app_message, on_app_message=self._on_app_message,
on_dialin_ready=self._on_dialin_ready,
on_dialout_connected=self._on_dialout_connected, on_dialout_connected=self._on_dialout_connected,
on_dialout_stopped=self._on_dialout_stopped, on_dialout_stopped=self._on_dialout_stopped,
on_dialout_error=self._on_dialout_error, on_dialout_error=self._on_dialout_error,
@@ -643,6 +648,7 @@ class DailyTransport(BaseTransport):
# these handlers. # these handlers.
self._register_event_handler("on_joined") self._register_event_handler("on_joined")
self._register_event_handler("on_left") self._register_event_handler("on_left")
self._register_event_handler("on_dialin_ready")
self._register_event_handler("on_dialout_connected") self._register_event_handler("on_dialout_connected")
self._register_event_handler("on_dialout_stopped") self._register_event_handler("on_dialout_stopped")
self._register_event_handler("on_dialout_error") self._register_event_handler("on_dialout_error")
@@ -715,6 +721,9 @@ class DailyTransport(BaseTransport):
if self._input: if self._input:
self._input.push_app_message(message, sender) self._input.push_app_message(message, sender)
def _on_dialin_ready(self, sip_endpoint):
self.on_dialin_ready(sip_endpoint)
def _on_dialout_connected(self, data): def _on_dialout_connected(self, data):
self.on_dialout_connected(data) self.on_dialout_connected(data)
@@ -759,6 +768,9 @@ class DailyTransport(BaseTransport):
def on_left(self): def on_left(self):
pass pass
def on_dialin_ready(self, sip_endpoint):
pass
def on_dialout_connected(self, data): def on_dialout_connected(self, data):
pass pass