bump protocol to v1.46.4 and expose client_protocol via FFI (#1121)

### PR description

- bumps the protocol to v1.46.4 and adds the `livekit_analytics.proto`
messages to the generated stubs.
- exposes participant `client_protocol` via FFI
- Adds a `remove_participant_with_options` method that allows to pass
new remove options to the API without a previous `remove_participant`
call breaking.

### Breaking changes

for the `livekit-api` crate I've added a `derive(default)` and an
additional (option) field to the EgressListOptions struct. I don't see a
good way around this though. Open for suggestions.

---------

Co-authored-by: github-actions <41898282+github-actions[bot]@users.noreply.github.com>

Author: lukasIO

.changeset/bump_protocol_to_v1_46_4.md

@@ -0,0 +1,10 @@
+---
+livekit: patch
+livekit-api: minor
+livekit-datatrack: patch
+livekit-ffi: patch
+livekit-protocol: patch
+livekit-uniffi: patch
+---
+
+bump protocol to v1.46.4 - #1121 (@lukasIO)

.gitattributes

@@ -0,0 +1,3 @@
+# Generated from the LiveKit protocol definitions; do not edit by hand.
+livekit-protocol/src/livekit.rs linguist-generated=true
+livekit-protocol/src/livekit.serde.rs linguist-generated=true

livekit-api/src/services/egress.rs

@@ -84,17 +84,20 @@ pub enum TrackEgressOutput {
     WebSocket(String),
 }
 
-#[derive(Debug, Clone)]
+#[derive(Debug, Clone, Default)]
 pub enum EgressListFilter {
+    #[default]
     All,
     Egress(String),
     Room(String),
 }
 
-#[derive(Debug, Clone)]
+#[derive(Debug, Clone, Default)]
 pub struct EgressListOptions {
     pub filter: EgressListFilter,
     pub active: bool,
+    /// Pagination token, e.g. from a previous response's `next_page_token`.
+    pub page_token: Option<proto::TokenPagination>,
 }
 
 const SVC: &str = "Egress";
@@ -340,7 +343,12 @@ impl EgressClient {
             .request(
                 SVC,
                 "ListEgress",
-                proto::ListEgressRequest { room_name, egress_id, active: options.active },
+                proto::ListEgressRequest {
+                    room_name,
+                    egress_id,
+                    active: options.active,
+                    page_token: options.page_token,
+                },
                 self.base
                     .auth_header(VideoGrants { room_record: true, ..Default::default() }, None)?,
             )

livekit-api/src/services/room.rs

@@ -39,6 +39,12 @@ pub struct UpdateParticipantOptions {
     pub name: String, // No effect if left empty
 }
 
+#[derive(Debug, Clone, Default)]
+pub struct RemoveParticipantOptions {
+    /// Revoke all tokens issued to this participant before this Unix timestamp (ms).
+    pub revoke_token_ts: i64,
+}
+
 #[derive(Debug, Clone, Default)]
 pub struct SendDataOptions {
     pub kind: proto::data_packet::Kind,
@@ -206,6 +212,7 @@ impl RoomClient {
                 proto::RoomParticipantIdentity {
                     room: room.to_owned(),
                     identity: identity.to_owned(),
+                    ..Default::default()
                 },
                 self.base.auth_header(
                     VideoGrants { room_admin: true, room: room.to_owned(), ..Default::default() },
@@ -217,13 +224,24 @@ impl RoomClient {
     }
 
     pub async fn remove_participant(&self, room: &str, identity: &str) -> ServiceResult<()> {
+        self.remove_participant_with_options(room, identity, RemoveParticipantOptions::default())
+            .await
+    }
+
+    pub async fn remove_participant_with_options(
+        &self,
+        room: &str,
+        identity: &str,
+        options: RemoveParticipantOptions,
+    ) -> ServiceResult<()> {
         self.client
             .request(
                 SVC,
                 "RemoveParticipant",
                 proto::RoomParticipantIdentity {
                     room: room.to_owned(),
                     identity: identity.to_owned(),
+                    revoke_token_ts: options.revoke_token_ts,
                 },
                 self.base.auth_header(
                     VideoGrants { room_admin: true, room: room.to_owned(), ..Default::default() },

livekit-api/src/services/sip.rs

@@ -78,6 +78,8 @@ pub struct CreateSIPInboundTrunkOptions {
     pub max_call_duration: Option<Duration>,
     pub ringing_timeout: Option<Duration>,
     pub krisp_enabled: Option<bool>,
+    /// Authentication realm advertised on inbound SIP invites.
+    pub auth_realm: Option<String>,
 }
 
 #[derive(Default, Clone, Debug)]
@@ -191,6 +193,7 @@ impl SIPClient {
                         allowed_addresses: options.allowed_addresses.unwrap_or_default(),
                         auth_username: options.auth_username.unwrap_or_default(),
                         auth_password: options.auth_password.unwrap_or_default(),
+                        auth_realm: options.auth_realm.unwrap_or_default(),
                         headers: options.headers.unwrap_or_default(),
                         headers_to_attributes: options.headers_to_attributes.unwrap_or_default(),
                         attributes_to_headers: options.attributes_to_headers.unwrap_or_default(),

livekit-ffi-node-bindings/proto/participant_pb.d.ts

@@ -294,6 +294,11 @@ export declare class ParticipantInfo extends Message<ParticipantInfo> {
    */
   permission?: ParticipantPermission;
 
+  /**
+   * @generated from field: required int32 client_protocol = 12;
+   */
+  clientProtocol?: number;
+
   constructor(data?: PartialMessage<ParticipantInfo>);
 
   static readonly runtime: typeof proto2;

livekit-ffi-node-bindings/proto/participant_pb.js

@@ -110,6 +110,7 @@ const ParticipantInfo = /*@__PURE__*/ proto2.makeMessageType(
     { no: 9, name: "joined_at", kind: "scalar", T: 3 /* ScalarType.INT64 */, req: true },
     { no: 10, name: "kind_details", kind: "enum", T: proto2.getEnumType(ParticipantKindDetail), repeated: true },
     { no: 11, name: "permission", kind: "message", T: ParticipantPermission, opt: true },
+    { no: 12, name: "client_protocol", kind: "scalar", T: 5 /* ScalarType.INT32 */, req: true },
   ],
 );
 

livekit-ffi/protocol/participant.proto

@@ -33,6 +33,7 @@ message ParticipantInfo {
   required int64 joined_at = 9;
   repeated ParticipantKindDetail kind_details = 10;
   optional ParticipantPermission permission = 11;
+  required int32 client_protocol = 12;
 }
 
 message OwnedParticipant {

livekit-ffi/src/conversion/participant.rs

@@ -48,6 +48,7 @@ impl From<&Participant> for proto::ParticipantInfo {
                 .map(|k| proto::ParticipantKindDetail::from(k).into())
                 .collect(),
             permission,
+            client_protocol: participant.client_protocol(),
         }
     }
 }

livekit-protocol/generate_proto.sh

@@ -34,4 +34,5 @@ protoc \
     $PROTOCOL/livekit_models.proto \
     $PROTOCOL/livekit_connector.proto \
     $PROTOCOL/livekit_connector_whatsapp.proto \
-    $PROTOCOL/livekit_connector_twilio.proto
+    $PROTOCOL/livekit_connector_twilio.proto \
+    $PROTOCOL/livekit_analytics.proto