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

transports(daily): fix on_participant_left event

Browse Source
This commit is contained in:
Aleix Conchillo Flaqué
2024-05-15 15:40:25 -07:00
parent 3d6783ddb0
commit 28da747f19
1 changed files with 6 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -102,7 +102,7 @@ class DailyCallbacks(BaseModel):
on_joined: Callable[[Mapping[str, Any]], None] on_joined: Callable[[Mapping[str, Any]], None]
on_left: Callable[[], None] on_left: Callable[[], None]
on_participant_joined: Callable[[Mapping[str, Any]], None] on_participant_joined: Callable[[Mapping[str, Any]], None]
on_participant_left: Callable[[Mapping[str, Any]], None] on_participant_left: Callable[[Mapping[str, Any], str], None]
on_first_participant_joined: Callable[[Mapping[str, Any]], None] on_first_participant_joined: Callable[[Mapping[str, Any]], None]
on_error: Callable[[str], None] on_error: Callable[[str], None]
@@ -376,11 +376,11 @@ class DailyTransportClient(EventHandler):
self._callbacks.on_participant_joined(participant) self._callbacks.on_participant_joined(participant)
def on_participant_leave(self, participant): def on_participant_left(self, participant, reason):
id = participant["id"] id = participant["id"]
logger.info(f"Participant left {id}") logger.info(f"Participant left {id}")
self._callbacks.on_participant_left(participant) self._callbacks.on_participant_left(participant, reason)
def on_transcription_message(self, message: Mapping[str, Any]): def on_transcription_message(self, message: Mapping[str, Any]):
participant_id = "" participant_id = ""
@@ -655,8 +655,8 @@ class DailyTransport(BaseTransport):
def _on_participant_joined(self, participant): def _on_participant_joined(self, participant):
self.on_participant_joined(participant) self.on_participant_joined(participant)
def _on_participant_left(self, participant): def _on_participant_left(self, participant, reason):
self.on_participant_left(participant) self.on_participant_left(participant, reason)
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)
@@ -688,7 +688,7 @@ class DailyTransport(BaseTransport):
def on_participant_joined(self, participant): def on_participant_joined(self, participant):
pass pass
def on_participant_left(self, participant): def on_participant_left(self, participant, reason):
pass pass
def on_first_participant_joined(self, participant): def on_first_participant_joined(self, participant):