livekit-ffi: add DisconnectReason

livekit-ffi/protocol/room.proto

@@ -268,6 +268,30 @@ enum DataPacketKind {
   KIND_RELIABLE = 1;
 }
 
+enum DisconnectReason {
+  UNKNOWN_REASON = 0;
+  // the client initiated the disconnect
+  CLIENT_INITIATED = 1;
+  // another participant with the same identity has joined the room
+  DUPLICATE_IDENTITY = 2;
+  // the server instance is shutting down
+  SERVER_SHUTDOWN = 3;
+  // RoomService.RemoveParticipant was called
+  PARTICIPANT_REMOVED = 4;
+  // RoomService.DeleteRoom was called
+  ROOM_DELETED = 5;
+  // the client is attempting to resume a session, but server is not aware of it
+  STATE_MISMATCH = 6;
+  // client was unable to connect fully
+  JOIN_FAILURE = 7;
+  // Cloud-only, the server requested Participant to migrate the connection elsewhere
+  MIGRATION = 8;
+  // the signal websocket was closed unexpectedly
+  SIGNAL_CLOSE = 9;
+  // the room was closed, due to all Standard and Ingress participants having left
+  ROOM_CLOSED = 10;
+}
+
 message TranscriptionSegment {
   string id = 1;
   string text = 2;
@@ -450,7 +474,9 @@ message TranscriptionReceived {
 message ConnectionStateChanged { ConnectionState state = 1; }
 
 message Connected {}
-message Disconnected {}
+message Disconnected {
+  DisconnectReason reason = 1;
+}
 message Reconnecting {}
 message Reconnected {}
 

livekit-ffi/src/conversion/room.rs

@@ -82,6 +82,24 @@ impl From<EncryptionType> for proto::EncryptionType {
     }
 }
 
+impl From<DisconnectReason> for proto::DisconnectReason {
+    fn from(value: DisconnectReason) -> Self {
+        match value {
+            DisconnectReason::UnknownReason => Self::UnknownReason,
+            DisconnectReason::ClientInitiated => Self::ClientInitiated,
+            DisconnectReason::DuplicateIdentity => Self::DuplicateIdentity,
+            DisconnectReason::ServerShutdown => Self::ServerShutdown,
+            DisconnectReason::ParticipantRemoved => Self::ParticipantRemoved,
+            DisconnectReason::RoomDeleted => Self::RoomDeleted,
+            DisconnectReason::StateMismatch => Self::StateMismatch,
+            DisconnectReason::JoinFailure => Self::JoinFailure,
+            DisconnectReason::Migration => Self::Migration,
+            DisconnectReason::SignalClose => Self::SignalClose,
+            DisconnectReason::RoomClosed => Self::RoomClosed,
+        }
+    }
+}
+
 impl From<proto::KeyProviderOptions> for KeyProviderOptions {
     fn from(value: proto::KeyProviderOptions) -> Self {
         Self {

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 {
@@ -2608,6 +2607,8 @@ pub struct Connected {
 #[allow(clippy::derive_partial_eq_without_eq)]
 #[derive(Clone, PartialEq, ::prost::Message)]
 pub struct Disconnected {
+    #[prost(enumeration="DisconnectReason", tag="1")]
+    pub reason: i32,
 }
 #[allow(clippy::derive_partial_eq_without_eq)]
 #[derive(Clone, PartialEq, ::prost::Message)]
@@ -2767,6 +2768,69 @@ impl DataPacketKind {
         }
     }
 }
+#[derive(Clone, Copy, Debug, PartialEq, Eq, Hash, PartialOrd, Ord, ::prost::Enumeration)]
+#[repr(i32)]
+pub enum DisconnectReason {
+    UnknownReason = 0,
+    /// the client initiated the disconnect
+    ClientInitiated = 1,
+    /// another participant with the same identity has joined the room
+    DuplicateIdentity = 2,
+    /// the server instance is shutting down
+    ServerShutdown = 3,
+    /// RoomService.RemoveParticipant was called
+    ParticipantRemoved = 4,
+    /// RoomService.DeleteRoom was called
+    RoomDeleted = 5,
+    /// the client is attempting to resume a session, but server is not aware of it
+    StateMismatch = 6,
+    /// client was unable to connect fully
+    JoinFailure = 7,
+    /// Cloud-only, the server requested Participant to migrate the connection elsewhere
+    Migration = 8,
+    /// the signal websocket was closed unexpectedly
+    SignalClose = 9,
+    /// the room was closed, due to all Standard and Ingress participants having left
+    RoomClosed = 10,
+}
+impl DisconnectReason {
+    /// String value of the enum field names used in the ProtoBuf definition.
+    ///
+    /// The values are not transformed in any way and thus are considered stable
+    /// (if the ProtoBuf definition does not change) and safe for programmatic use.
+    pub fn as_str_name(&self) -> &'static str {
+        match self {
+            DisconnectReason::UnknownReason => "UNKNOWN_REASON",
+            DisconnectReason::ClientInitiated => "CLIENT_INITIATED",
+            DisconnectReason::DuplicateIdentity => "DUPLICATE_IDENTITY",
+            DisconnectReason::ServerShutdown => "SERVER_SHUTDOWN",
+            DisconnectReason::ParticipantRemoved => "PARTICIPANT_REMOVED",
+            DisconnectReason::RoomDeleted => "ROOM_DELETED",
+            DisconnectReason::StateMismatch => "STATE_MISMATCH",
+            DisconnectReason::JoinFailure => "JOIN_FAILURE",
+            DisconnectReason::Migration => "MIGRATION",
+            DisconnectReason::SignalClose => "SIGNAL_CLOSE",
+            DisconnectReason::RoomClosed => "ROOM_CLOSED",
+        }
+    }
+    /// Creates an enum from field names used in the ProtoBuf definition.
+    pub fn from_str_name(value: &str) -> ::core::option::Option<Self> {
+        match value {
+            "UNKNOWN_REASON" => Some(Self::UnknownReason),
+            "CLIENT_INITIATED" => Some(Self::ClientInitiated),
+            "DUPLICATE_IDENTITY" => Some(Self::DuplicateIdentity),
+            "SERVER_SHUTDOWN" => Some(Self::ServerShutdown),
+            "PARTICIPANT_REMOVED" => Some(Self::ParticipantRemoved),
+            "ROOM_DELETED" => Some(Self::RoomDeleted),
+            "STATE_MISMATCH" => Some(Self::StateMismatch),
+            "JOIN_FAILURE" => Some(Self::JoinFailure),
+            "MIGRATION" => Some(Self::Migration),
+            "SIGNAL_CLOSE" => Some(Self::SignalClose),
+            "ROOM_CLOSED" => Some(Self::RoomClosed),
+            _ => None,
+        }
+    }
+}
 /// Create a new AudioStream
 /// AudioStream is used to receive audio frames from a track
 #[allow(clippy::derive_partial_eq_without_eq)]

livekit-ffi/src/server/room.rs

@@ -964,8 +964,10 @@ async fn forward_event(
         RoomEvent::Connected { .. } => {
             // Ignore here, we're already sent the event on connect (see above)
         }
-        RoomEvent::Disconnected { reason: _ } => {
-            let _ = send_event(proto::room_event::Message::Disconnected(proto::Disconnected {}));
+        RoomEvent::Disconnected { reason } => {
+            let _ = send_event(proto::room_event::Message::Disconnected(proto::Disconnected {
+                reason: proto::DisconnectReason::from(reason).into(),
+            }));
         }
         RoomEvent::Reconnecting => {
             present_state.lock().reconnecting = true;