room sid changed

livekit-rtc/livekit/rtc/participant.py

@@ -93,7 +93,7 @@ async def publish_data(
         self,
         payload: Union[bytes, str],
         reliable: bool = True,
-        destination_sids: List[Union[str, "RemoteParticipant"]] = [],
+        destination_identities: List[Union[str, "RemoteParticipant"]] = [],
         topic: str = "",
     ) -> None:
         if isinstance(payload, str):
@@ -110,13 +110,13 @@ async def publish_data(
         req.publish_data.topic = topic
 
         sids = []
-        for p in destination_sids:
+        for p in destination_identities:
             if isinstance(p, RemoteParticipant):
                 sids.append(p.sid)
             else:
                 sids.append(p)
 
-        req.publish_data.destination_sids.extend(sids)
+        req.publish_data.destination_identities.extend(sids)
 
         queue = FfiClient.instance.queue.subscribe()
         try:

livekit-rtc/livekit/rtc/room.py

@@ -45,6 +45,7 @@
     "track_unmuted",
     "active_speakers_changed",
     "room_metadata_changed",
+    "room_sid_changed",
     "participant_metadata_changed",
     "participant_name_changed",
     "connection_quality_changed",
@@ -360,6 +361,10 @@ def _on_room_event(self, event: proto_room.RoomEvent):
             old_metadata = self.metadata
             self._info.metadata = event.room_metadata_changed.metadata
             self.emit("room_metadata_changed", old_metadata, self.metadata)
+        elif which == "room_sid_changed":
+            old_sid = self.sid
+            self._info.sid = event.room_sid_changed.sid
+            self.emit("room_sid_changed", old_sid, self.sid)
         elif which == "participant_metadata_changed":
             sid = event.participant_metadata_changed.participant_sid
             # TODO: pass participant identity