Update rust ffi

README.md

@@ -108,7 +108,7 @@ async def main():
     # participants and tracks that are already available in the room
     # participant_connected and track_published events will *not* be emitted for them
     for participant in room.participants.items():
-        for publication in participant.tracks.items():
+        for publication in participant.track_publications.items():
             print("track publication: %s", publication.sid)
 ```
 

examples/basic_room.py

@@ -139,7 +139,7 @@ def on_reconnected() -> None:
     )
     await room.connect(os.getenv("LIVEKIT_URL"), token)
     logging.info("connected to room %s", room.name)
-    logging.info("participants: %s", room.participants)
+    logging.info("participants: %s", room.remote_participants)
 
     await asyncio.sleep(2)
     await room.local_participant.publish_data("hello world")

examples/participant_attributes.py

@@ -0,0 +1,71 @@
+import asyncio
+import logging
+from signal import SIGINT, SIGTERM
+import os
+
+from livekit import api, rtc
+
+# ensure LIVEKIT_URL, LIVEKIT_API_KEY, and LIVEKIT_API_SECRET are set
+
+
+async def main(room: rtc.Room) -> None:
+    token = (
+        api.AccessToken()
+        .with_identity("python-bot")
+        .with_name("Python Bot")
+        .with_grants(
+            api.VideoGrants(
+                room_join=True,
+                room="my-room",
+                can_update_own_metadata=True,
+            )
+        )
+        .to_jwt()
+    )
+
+    @room.on("participant_attributes_changed")
+    def on_participant_attributes_changed(
+        changed_attributes: dict[str, str], participant: rtc.Participant
+    ):
+        logging.info(
+            "participant attributes changed: %s %s",
+            participant.attributes,
+            changed_attributes,
+        )
+
+    await room.connect(os.getenv("LIVEKIT_URL"), token)
+    logging.info("connected to room %s", room.name)
+
+    # Create an attribute
+    await room.local_participant.set_attributes({"foo": "bar"})
+    # Delete an attribute
+    await room.local_participant.set_attributes({"foo": ""})
+
+    # Create another attribute
+    await room.local_participant.set_attributes({"baz": "qux"})
+
+    # Update an attribute
+    await room.local_participant.set_attributes({"baz": "biz"})
+
+
+if __name__ == "__main__":
+    logging.basicConfig(
+        level=logging.INFO,
+        handlers=[logging.FileHandler("basic_room.log"), logging.StreamHandler()],
+    )
+
+    loop = asyncio.get_event_loop()
+    room = rtc.Room(loop=loop)
+
+    async def cleanup():
+        await room.disconnect()
+        loop.stop()
+
+    asyncio.ensure_future(main(room))
+    for signal in [SIGINT, SIGTERM]:
+        loop.add_signal_handler(signal, lambda: asyncio.ensure_future(cleanup()))
+
+    try:
+        loop.run_forever()
+    finally:
+        loop.close()

livekit-protocol/generate_proto.sh

@@ -31,6 +31,7 @@ protoc \
     $API_PROTOCOL/livekit_ingress.proto \
     $API_PROTOCOL/livekit_models.proto \
     $API_PROTOCOL/livekit_agent.proto \
+    $API_PROTOCOL/livekit_agent_dispatch.proto \
     $API_PROTOCOL/livekit_sip.proto \
     $API_PROTOCOL/livekit_analytics.proto
 
@@ -58,11 +59,13 @@ mv "$API_OUT_PYTHON/livekit_models_pb2.py" "$API_OUT_PYTHON/models.py"
 mv "$API_OUT_PYTHON/livekit_models_pb2.pyi" "$API_OUT_PYTHON/models.pyi"
 mv "$API_OUT_PYTHON/livekit_agent_pb2.py" "$API_OUT_PYTHON/agent.py"
 mv "$API_OUT_PYTHON/livekit_agent_pb2.pyi" "$API_OUT_PYTHON/agent.pyi"
+mv "$API_OUT_PYTHON/livekit_agent_dispatch_pb2.py" "$API_OUT_PYTHON/agent_dispatch.py"
+mv "$API_OUT_PYTHON/livekit_agent_dispatch_pb2.pyi" "$API_OUT_PYTHON/agent_dispatch.pyi"
 mv "$API_OUT_PYTHON/livekit_analytics_pb2.py" "$API_OUT_PYTHON/analytics.py"
 mv "$API_OUT_PYTHON/livekit_analytics_pb2.pyi" "$API_OUT_PYTHON/analytics.pyi"
 mv "$API_OUT_PYTHON/livekit_sip_pb2.py" "$API_OUT_PYTHON/sip.py"
 mv "$API_OUT_PYTHON/livekit_sip_pb2.pyi" "$API_OUT_PYTHON/sip.pyi"
 
-perl -i -pe 's|^(import (livekit_egress_pb2\|livekit_room_pb2\|livekit_webhook_pb2\|livekit_ingress_pb2\|livekit_models_pb2\|livekit_agent_pb2\|livekit_analytics_pb2\|livekit_sip_pb2))|from . $1|g' "$API_OUT_PYTHON"/*.py "$API_OUT_PYTHON"/*.pyi
+perl -i -pe 's|^(import (livekit_egress_pb2\|livekit_room_pb2\|livekit_webhook_pb2\|livekit_ingress_pb2\|livekit_models_pb2\|livekit_agent_pb2\|livekit_agent_dispatch_pb2\|livekit_analytics_pb2\|livekit_sip_pb2))|from . $1|g' "$API_OUT_PYTHON"/*.py "$API_OUT_PYTHON"/*.pyi
 
 perl -i -pe 's|livekit_(\w+)_pb2|${1}|g' "$API_OUT_PYTHON"/*.py "$API_OUT_PYTHON"/*.pyi