livekit-ffi: destination_{sids -> identities}

Author: nbsp

livekit-ffi/protocol/room.proto

@@ -89,8 +89,9 @@ message PublishDataRequest {
   uint64 data_ptr = 2;
   uint64 data_len = 3;
   DataPacketKind kind = 4;
-  repeated string destination_sids = 5; // destination
+  repeated string destination_sids = 5;
   optional string topic = 6;
+  repeated string destination_identities = 7;
 }
 message PublishDataResponse {
   uint64 async_id = 1;

livekit-ffi/src/livekit.proto.rs

@@ -1,5 +1,4 @@
 // @generated
-// This file is @generated by prost-build.
 #[allow(clippy::derive_partial_eq_without_eq)]
 #[derive(Clone, PartialEq, ::prost::Message)]
 pub struct FrameCryptor {
@@ -2021,11 +2020,12 @@ pub struct PublishDataRequest {
     pub data_len: u64,
     #[prost(enumeration="DataPacketKind", tag="4")]
     pub kind: i32,
-    /// destination
     #[prost(string, repeated, tag="5")]
     pub destination_sids: ::prost::alloc::vec::Vec<::prost::alloc::string::String>,
     #[prost(string, optional, tag="6")]
     pub topic: ::core::option::Option<::prost::alloc::string::String>,
+    #[prost(string, repeated, tag="7")]
+    pub destination_identities: ::prost::alloc::vec::Vec<::prost::alloc::string::String>,
 }
 #[allow(clippy::derive_partial_eq_without_eq)]
 #[derive(Clone, PartialEq, ::prost::Message)]
@@ -2044,20 +2044,6 @@ pub struct PublishDataCallback {
 /// Publish transcription messages to room
 #[allow(clippy::derive_partial_eq_without_eq)]
 #[derive(Clone, PartialEq, ::prost::Message)]
-pub struct TranscriptionSegment {
-    #[prost(string, tag="1")]
-    pub id: ::prost::alloc::string::String,
-    #[prost(string, tag="2")]
-    pub text: ::prost::alloc::string::String,
-    #[prost(uint64, tag="3")]
-    pub start_time: u64,
-    #[prost(uint64, tag="4")]
-    pub end_time: u64,
-    #[prost(bool, tag="5")]
-    pub r#final: bool,
-}
-#[allow(clippy::derive_partial_eq_without_eq)]
-#[derive(Clone, PartialEq, ::prost::Message)]
 pub struct PublishTranscriptionRequest {
     #[prost(uint64, tag="1")]
     pub local_participant_handle: u64,
@@ -2240,6 +2226,20 @@ pub struct RoomOptions {
 }
 #[allow(clippy::derive_partial_eq_without_eq)]
 #[derive(Clone, PartialEq, ::prost::Message)]
+pub struct TranscriptionSegment {
+    #[prost(string, tag="1")]
+    pub id: ::prost::alloc::string::String,
+    #[prost(string, tag="2")]
+    pub text: ::prost::alloc::string::String,
+    #[prost(uint64, tag="3")]
+    pub start_time: u64,
+    #[prost(uint64, tag="4")]
+    pub end_time: u64,
+    #[prost(bool, tag="5")]
+    pub r#final: bool,
+}
+#[allow(clippy::derive_partial_eq_without_eq)]
+#[derive(Clone, PartialEq, ::prost::Message)]
 pub struct BufferInfo {
     #[prost(uint64, tag="1")]
     pub data_ptr: u64,

livekit-ffi/src/server/room.rs

@@ -238,19 +238,21 @@ impl RoomInner {
         .to_vec();
 
         let kind = publish.kind();
-        let destination_sids = publish.destination_sids;
+        let destination_identities = publish.destination_identities;
         let async_id = server.next_id();
 
         if let Err(err) = self.data_tx.send(FfiDataPacket {
             payload: DataPacket {
                 payload: data.to_vec(), // Avoid copy?
-                kind: kind.into(),
+                reliable: match kind {
+                    proto::DataPacketKind::KindLossy => false,
+                    proto::DataPacketKind::KindReliable => true,
+                },
                 topic: publish.topic,
-                destination_sids: destination_sids
+                destination_identities: destination_identities
                     .into_iter()
                     .map(|str| str.try_into().unwrap())
                     .collect(),
-                destination_identities: Vec::new(), // TODO
             },
             async_id,
         }) {