Add support for data channel encryption (#549)

* wip datachannel encryption

* Expose participantEncryptionChanged event and update rust sdks

* Create witty-olives-explain.md

Author: lukasIO

.changeset/witty-olives-explain.md

@@ -0,0 +1,5 @@
+---
+"@livekit/rtc-node": patch
+---
+
+Add support for data channel encryption

packages/livekit-rtc/src/room.ts

@@ -18,7 +18,7 @@ import { FfiClient, FfiClientEvent, FfiHandle } from './ffi_client.js';
 import { log } from './log.js';
 import type { Participant } from './participant.js';
 import { LocalParticipant, RemoteParticipant } from './participant.js';
-import { EncryptionState } from './proto/e2ee_pb.js';
+import { EncryptionState, EncryptionType } from './proto/e2ee_pb.js';
 import type { FfiEvent } from './proto/ffi_pb.js';
 import type { DisconnectReason, OwnedParticipant } from './proto/participant_pb.js';
 import type { DataStream_Trailer } from './proto/room_pb.js';
@@ -61,14 +61,19 @@ export const defaultRtcConfiguration: RtcConfiguration = {
 export interface RoomOptions {
   autoSubscribe: boolean;
   dynacast: boolean;
+  /**
+   * @deprecated Use `encryption` instead. See x for details
+   */
   e2ee?: E2EEOptions;
+  encryption?: E2EEOptions;
   rtcConfig?: RtcConfiguration;
 }
 
 export const defaultRoomOptions = new FfiRoomOptions({
   autoSubscribe: true,
   dynacast: false,
   e2ee: undefined,
+  encryption: undefined,
   rtcConfig: undefined,
   adaptiveStream: false,
   joinRetries: 1,
@@ -181,7 +186,10 @@ export class Room extends (EventEmitter as new () => TypedEmitter<RoomCallbacks>
    */
   async connect(url: string, token: string, opts?: RoomOptions) {
     const options = { ...defaultRoomOptions, ...opts };
-    const e2eeOptions = { ...defaultE2EEOptions, ...options.e2ee };
+    const e2eeEnabled = options.encryption || options.e2ee;
+    const e2eeOptions = options.encryption
+      ? { ...defaultE2EEOptions, ...options.encryption }
+      : { ...defaultE2EEOptions, ...options.e2ee };
 
     const req = new ConnectRequest({
       url: url,
@@ -207,7 +215,7 @@ export class Room extends (EventEmitter as new () => TypedEmitter<RoomCallbacks>
     switch (cb.message.case) {
       case 'result':
         this.ffiHandle = new FfiHandle(cb.message.value.room!.handle!.id!);
-        this.e2eeManager = options.e2ee && new E2EEManager(this.ffiHandle.handle, e2eeOptions);
+        this.e2eeManager = e2eeEnabled && new E2EEManager(this.ffiHandle.handle, e2eeOptions);
 
         this.info = cb.message.value.room!.info;
         this.connectionState = ConnectionState.CONN_CONNECTED;
@@ -533,6 +541,13 @@ export class Room extends (EventEmitter as new () => TypedEmitter<RoomCallbacks>
             participant.info = info;
           }
         }
+      } else if (ev.case === 'participantEncryptionStatusChanged') {
+        const participant = this.requireParticipantByIdentity(ev.value.participantIdentity!);
+        this.emit(
+          RoomEvent.ParticipantEncryptionStatusChanged,
+          !!ev.value.isEncrypted,
+          participant,
+        );
       }
     } finally {
       unlock();
@@ -737,12 +752,14 @@ export type RoomCallbacks = {
     changedAttributes: Record<string, string>,
     participant: Participant,
   ) => void;
+  participantEncryptionStatusChanged: (isEncrypted: boolean, participant: Participant) => void;
   connectionQualityChanged: (quality: ConnectionQuality, participant: Participant) => void;
   dataReceived: (
     payload: Uint8Array,
     participant?: RemoteParticipant,
     kind?: DataPacketKind,
     topic?: string,
+    encryptionType?: EncryptionType,
   ) => void;
   chatMessage: (message: ChatMessage, participant?: Participant) => void;
   dtmfReceived: (code: number, digit: string, participant: RemoteParticipant) => void;
@@ -776,6 +793,7 @@ export enum RoomEvent {
   ParticipantMetadataChanged = 'participantMetadataChanged',
   ParticipantNameChanged = 'participantNameChanged',
   ParticipantAttributesChanged = 'participantAttributesChanged',
+  ParticipantEncryptionStatusChanged = 'participantEncryptionStatusChanged',
   ConnectionQualityChanged = 'connectionQualityChanged',
   DataReceived = 'dataReceived',
   ChatMessage = 'chatMessage',