feat(RoomClient): implement forward participant api

.nanpa/forward-participant.kdl

@@ -0,0 +1 @@
+minor type="added" "Implement Forward Participant API"

livekit-api/src/access_token.rs

@@ -57,6 +57,8 @@ pub struct VideoGrants {
     pub room_join: bool,
     #[serde(default)]
     pub room: String,
+    #[serde(default)]
+    pub destination_room: String,
 
     // permissions within a room
     #[serde(default = "default_true")]
@@ -102,6 +104,7 @@ impl Default for VideoGrants {
             room_admin: false,
             room_join: false,
             room: "".to_string(),
+            destination_room: "".to_string(),
             can_publish: true,
             can_subscribe: true,
             can_publish_data: true,

livekit-api/src/services/egress.rs

@@ -153,6 +153,8 @@ impl EgressClient {
                     image_outputs,
                     output: None, // Deprecated
                     await_start_signal: options.await_start_signal,
+                    // TODO: egress webhooks
+                    ..Default::default()
                 },
                 self.base
                     .auth_header(VideoGrants { room_record: true, ..Default::default() }, None)?,
@@ -184,6 +186,8 @@ impl EgressClient {
                     stream_outputs,
                     segment_outputs,
                     image_outputs,
+                    // TODO: egress webhooks
+                    ..Default::default()
                 },
                 self.base
                     .auth_header(VideoGrants { room_record: true, ..Default::default() }, None)?,
@@ -215,6 +219,8 @@ impl EgressClient {
                     segment_outputs,
                     image_outputs,
                     output: None, // Deprecated
+                    // TODO: egress webhooks
+                    ..Default::default()
                 },
                 self.base
                     .auth_header(VideoGrants { room_record: true, ..Default::default() }, None)?,
@@ -244,6 +250,8 @@ impl EgressClient {
                         }
                     },
                     track_id: track_id.to_string(),
+                    // TODO: egress webhooks
+                    ..Default::default()
                 },
                 self.base
                     .auth_header(VideoGrants { room_record: true, ..Default::default() }, None)?,

livekit-api/src/services/room.rs

@@ -201,6 +201,26 @@ impl RoomClient {
             .map_err(Into::into)
     }
 
+    pub async fn forward_participant(
+        &self,
+        room: &str,
+        identity: &str,
+        destination_room: &str,
+    ) -> ServiceResult<(proto::ForwardParticipantResponse)> {
+        self.client
+            .request(
+                SVC,
+                "ForwardParticipant",
+                proto::ForwardParticipantRequest{ room: room.to_owned(), identity: identity.to_owned(), destination_room: destination_room.to_owned() },
+                self.base.auth_header(
+                    VideoGrants { room_admin: true, room: room.to_owned(), destination_room: destination_room.to_owned(), ..Default::default() },
+                    None,
+                )?,
+            )
+            .await
+            .map_err(Into::into)
+    }
+
     pub async fn mute_published_track(
         &self,
         room: &str,

livekit-api/src/services/sip.rs

@@ -346,17 +346,17 @@ impl SIPClient {
                 SVC,
                 "CreateSIPDispatchRule",
                 proto::CreateSipDispatchRuleRequest {
-                    name: options.name,
-                    metadata: options.metadata,
-                    attributes: options.attributes,
-                    trunk_ids: options.trunk_ids.to_owned(),
-                    inbound_numbers: options.allowed_numbers.to_owned(),
-                    hide_phone_number: options.hide_phone_number,
-                    rule: Some(proto::SipDispatchRule { rule: Some(rule.to_owned()) }),
-
-                    // TODO: support these attributes
-                    room_preset: Default::default(),
-                    room_config: Default::default(),
+                    dispatch_rule: Some(proto::SipDispatchRuleInfo {
+                        name: options.name,
+                        metadata: options.metadata,
+                        attributes: options.attributes,
+                        trunk_ids: options.trunk_ids.to_owned(),
+                        inbound_numbers: options.allowed_numbers.to_owned(),
+                        hide_phone_number: options.hide_phone_number,
+                        rule: Some(proto::SipDispatchRule { rule: Some(rule.to_owned()) }),
+                        ..Default::default()
+                    }),
+                    ..Default::default()
                 },
                 self.base.auth_header(
                     Default::default(),

livekit-ffi/protocol/participant.proto

@@ -70,4 +70,6 @@ enum DisconnectReason {
   USER_REJECTED = 12;
   // SIP protocol failure or unexpected response
   SIP_TRUNK_FAILURE = 13;
+  // server timed out a participant session
+  ConnectionTimeout = 14;
 }

livekit-ffi/src/conversion/participant.rs

@@ -61,6 +61,7 @@ impl From<DisconnectReason> for proto::DisconnectReason {
             DisconnectReason::UserUnavailable => proto::DisconnectReason::UserUnavailable,
             DisconnectReason::UserRejected => proto::DisconnectReason::UserRejected,
             DisconnectReason::SipTrunkFailure => proto::DisconnectReason::SipTrunkFailure,
+            DisconnectReason::ConnectionTimeout => proto::DisconnectReason::ConnectionTimeout,
         }
     }
 }

livekit-ffi/src/conversion/room.rs

@@ -98,6 +98,7 @@ impl From<DisconnectReason> for proto::DisconnectReason {
             DisconnectReason::UserUnavailable => Self::UserUnavailable,
             DisconnectReason::UserRejected => Self::UserRejected,
             DisconnectReason::SipTrunkFailure => Self::SipTrunkFailure,
+            DisconnectReason::ConnectionTimeout => Self::ConnectionTimeout,
         }
     }
 }

livekit-ffi/src/livekit.proto.rs

@@ -1694,6 +1694,8 @@ pub enum DisconnectReason {
     UserRejected = 12,
     /// SIP protocol failure or unexpected response
     SipTrunkFailure = 13,
+    /// server timed out a participant session
+    ConnectionTimeout = 14,
 }
 impl DisconnectReason {
     /// String value of the enum field names used in the ProtoBuf definition.
@@ -1716,6 +1718,7 @@ impl DisconnectReason {
             DisconnectReason::UserUnavailable => "USER_UNAVAILABLE",
             DisconnectReason::UserRejected => "USER_REJECTED",
             DisconnectReason::SipTrunkFailure => "SIP_TRUNK_FAILURE",
+            DisconnectReason::ConnectionTimeout => "ConnectionTimeout",
         }
     }
     /// Creates an enum from field names used in the ProtoBuf definition.
@@ -1735,6 +1738,7 @@ impl DisconnectReason {
             "USER_UNAVAILABLE" => Some(Self::UserUnavailable),
             "USER_REJECTED" => Some(Self::UserRejected),
             "SIP_TRUNK_FAILURE" => Some(Self::SipTrunkFailure),
+            "ConnectionTimeout" => Some(Self::ConnectionTimeout),
             _ => None,
         }
     }