implement wrapper

Author: davidzhao

examples/basic_room.py

@@ -117,6 +117,10 @@ def on_reconnecting() -> None:
     def on_reconnected() -> None:
         logging.info("reconnected")
 
+    @room.on("room_updated")
+    def on_room_updated() -> None:
+        logging.info(f"room updated, participants: {room.num_participants}")
+
     token = (
         api.AccessToken()
         .with_identity("python-bot")
@@ -130,8 +134,8 @@ def on_reconnected() -> None:
         .to_jwt()
     )
     await room.connect(os.getenv("LIVEKIT_URL"), token)
-    logging.info("connected to room %s", room.name)
-    logging.info("participants: %s", room.remote_participants)
+    logging.info(f"connected to room {room.name}, created {room.creation_time}")
+    logging.info(f"participants: {room.remote_participants}")
 
     await asyncio.sleep(2)
     await room.local_participant.publish_data("hello world")

livekit-rtc/livekit/rtc/room.py

@@ -13,6 +13,7 @@
 # limitations under the License.
 from __future__ import annotations
 
+import datetime
 import asyncio
 import ctypes
 import logging
@@ -70,6 +71,8 @@
     "disconnected",
     "reconnecting",
     "reconnected",
+    "room_updated",
+    "moved",
 ]
 
 
@@ -234,6 +237,60 @@ def e2ee_manager(self) -> E2EEManager:
             E2EEManager: The E2EE manager instance.
         """
         return self._e2ee_manager
+    
+    @property
+    def num_participants(self) -> int:
+        """Gets the number of participants in the room.
+        
+        Returns:
+            int: The number of participants in the room.
+        """
+        return self._info.num_participants
+    
+    @property
+    def num_publishers(self) -> int:
+        """Gets the number of publishers in the room.
+        
+        Returns:
+            int: The number of publishers in the room.
+        """
+        return self._info.num_publishers
+    
+    @property
+    def creation_time(self) -> datetime.datetime:
+        """Time when the room was created.
+        
+        Returns:
+            datetime.datetime: The creation time of the room.
+        """
+        return datetime.datetime.fromtimestamp(self._info.creation_time / 1000, datetime.timezone.utc)
+    
+    @property
+    def is_recording(self) -> bool:
+        """Whether the room is actively recording.
+        
+        Returns:
+            bool: True if actively recording, False otherwise.
+        """
+        return self._info.active_recording
+    
+    @property
+    def departure_timeout(self) -> float:
+        """Amount of time to hold the room open after the last standard participant leaves.
+        
+        Returns:
+            float: The departure timeout of the room.
+        """
+        return float(self._info.departure_timeout)
+    
+    @property
+    def empty_timeout(self) -> float:
+        """Amount of time to keep the room open if no participants join.
+        
+        Returns:
+            float: The empty timeout of the room.
+        """
+        return float(self._info.empty_timeout)
 
     def isconnected(self) -> bool:
         """Checks if the room is currently connected.
@@ -311,6 +368,10 @@ def on(self, event: EventTypes, callback: Optional[Callable] = None) -> Callable
                 - Arguments: None
             - **"reconnected"**: Called when the room has successfully reconnected.
                 - Arguments: None
+            - **"room_updated"**: Called when any information about the room is updated.
+                - Arguments: None
+            - **"moved"**: Called when the participant has been moved to another room.
+                - Arguments: None
 
         Example:
             ```python
@@ -771,7 +832,18 @@ def _on_room_event(self, event: proto_room.RoomEvent):
             task.add_done_callback(self._data_stream_tasks.discard)
 
         elif which == "room_updated":
-            print(f"received room update: {event.room_updated}")
+            self._info = event.room_updated
+            self.emit("room_updated")
+
+        elif which == "moved":
+            self._info = event.moved
+            self.emit("moved")
+
+        elif which == "participants_updated":
+            for info in event.participants_updated.participants:
+                participant = self._retrieve_participant(info.identity)
+                if participant:
+                    participant._info = info
 
     def _handle_stream_header(
         self, header: proto_room.DataStream.Header, participant_identity: str