Rename Tavus event, on_connected

src/pipecat/transports/tavus/transport.py

@@ -134,12 +134,12 @@ class TavusCallbacks(BaseModel):
     """Callback handlers for Tavus events.
 
     Parameters:
-        on_joined: Called when the bot joins the Daily room.
+        on_connected: Called when the bot connects to the room.
         on_participant_joined: Called when a participant joins the conversation.
         on_participant_left: Called when a participant leaves the conversation.
     """
 
-    on_joined: Callable[[Mapping[str, Any]], Awaitable[None]]
+    on_connected: Callable[[Mapping[str, Any]], Awaitable[None]]
     on_participant_joined: Callable[[Mapping[str, Any]], Awaitable[None]]
     on_participant_left: Callable[[Mapping[str, Any], str], Awaitable[None]]
 
@@ -274,7 +274,7 @@ class TavusTransportClient:
     async def _on_joined(self, data):
         """Handle joined event."""
         logger.debug("TavusTransportClient joined!")
-        await self._callbacks.on_joined(data)
+        await self._callbacks.on_connected(data)
 
     async def _on_left(self):
         """Handle left event."""
@@ -669,6 +669,7 @@ class TavusTransport(BaseTransport):
 
     Event handlers available:
 
+    - on_connected(transport, data): Bot connected to the room
     - on_client_connected(transport, participant): Participant connected to the session
     - on_client_disconnected(transport, participant): Participant disconnected from the session
 
@@ -707,7 +708,7 @@ class TavusTransport(BaseTransport):
         self._params = params
 
         callbacks = TavusCallbacks(
-            on_joined=self._on_joined,
+            on_connected=self._on_joined,
             on_participant_joined=self._on_participant_joined,
             on_participant_left=self._on_participant_left,
         )
@@ -726,13 +727,13 @@ class TavusTransport(BaseTransport):
 
         # Register supported handlers. The user will only be able to register
         # these handlers.
-        self._register_event_handler("on_joined")
+        self._register_event_handler("on_connected")
         self._register_event_handler("on_client_connected")
         self._register_event_handler("on_client_disconnected")
 
     async def _on_joined(self, data):
         """Handle bot joined room event."""
-        await self._call_event_handler("on_joined", data)
+        await self._call_event_handler("on_connected", data)
         if self._input:
             await self._input.push_frame(BotConnectedFrame())