Bump livekit-ffi to 0.12.73

.changeset/thirty-steaks-move.md

@@ -0,0 +1,5 @@
+---
+'@livekit/rtc-node': patch
+---
+
+Update to livekit ffi 0.12.73

packages/livekit-rtc/package.json

@@ -31,7 +31,7 @@
   "dependencies": {
     "@datastructures-js/deque": "1.0.8",
     "@livekit/mutex": "^1.0.0",
-    "@livekit/rtc-ffi-bindings": "0.12.68",
+    "@livekit/rtc-ffi-bindings": "0.12.73",
     "@livekit/typed-emitter": "^3.0.0",
     "pino": "^9.0.0",
     "pino-pretty": "^13.0.0"

packages/livekit-rtc/src/index.ts

@@ -36,7 +36,14 @@ export {
   TrackSource,
 } from '@livekit/rtc-ffi-bindings';
 export { VideoBufferType, VideoCodec, VideoRotation } from '@livekit/rtc-ffi-bindings';
-export { ConnectError, Room, RoomEvent, type RoomOptions, type RtcConfiguration } from './room.js';
+export {
+  ConnectError,
+  Room,
+  RoomEvent,
+  type RoomDataStreamOptions,
+  type RoomOptions,
+  type RtcConfiguration,
+} from './room.js';
 export { RpcError, type PerformRpcParams, type RpcInvocationData } from './rpc.js';
 export {
   LocalAudioTrack,

packages/livekit-rtc/src/participant.ts

@@ -277,6 +277,7 @@ export class LocalParticipant extends Participant {
     destinationIdentities?: Array<string>;
     streamId?: string;
     senderIdentity?: string;
+    totalSize?: number;
   }): Promise<TextStreamWriter> {
     const senderIdentity = options?.senderIdentity ?? this.identity;
     const streamId = options?.streamId ?? crypto.randomUUID();
@@ -287,6 +288,7 @@ export class LocalParticipant extends Participant {
       mimeType: 'text/plain',
       topic: options?.topic ?? '',
       timestamp: Date.now(),
+      totalSize: options?.totalSize,
     };
 
     const headerReq = new SendStreamHeaderRequest({
@@ -298,6 +300,7 @@ export class LocalParticipant extends Participant {
         mimeType: info.mimeType,
         topic: info.topic,
         timestamp: numberToBigInt(info.timestamp),
+        totalLength: numberToBigInt(info.totalSize),
         attributes: options?.attributes,
         contentHeader: {
           case: 'textHeader',
@@ -384,7 +387,10 @@ export class LocalParticipant extends Participant {
       streamId?: string;
     },
   ) {
-    const writer = await this.streamText(options);
+    const writer = await this.streamText({
+      ...options,
+      totalSize: new TextEncoder().encode(text).byteLength,
+    });
     await writer.write(text);
     await writer.close();
     return writer.info;

packages/livekit-rtc/src/room.ts

@@ -29,6 +29,7 @@ import {
   type IceServer,
   IceTransportType,
   type ReadyForRoomEventResponse,
+  RoomDataStreamOptions,
   type RoomInfo,
   type SimulateScenarioCallback,
   type SimulateScenarioKind,
@@ -58,6 +59,8 @@ import { RemoteTrackPublication } from './track_publication.js';
 import type { ChatMessage } from './types.js';
 import { bigIntToNumber } from './utils.js';
 
+export { RoomDataStreamOptions };
+
 export interface RtcConfiguration {
   iceTransportType: IceTransportType;
   continualGatheringPolicy: ContinualGatheringPolicy;
@@ -273,6 +276,13 @@ export class Room extends (EventEmitter as new () => TypedEmitter<RoomCallbacks>
    */
   async connect(url: string, token: string, opts?: RoomOptions) {
     const options = { ...defaultRoomOptions, ...opts };
+    // The Node SDK still implements data streams in TypeScript on top of raw FFI
+    // packets, so always advertise only legacy (v1) data stream support to other
+    // clients, preserving any other data stream options provided by the user.
+    options.dataStream = new RoomDataStreamOptions({
+      ...options.dataStream,
+      useLegacyClientImplementation: true,
+    });
     const e2eeEnabled = options.encryption || options.e2ee;
     const e2eeOptions = options.encryption
       ? { ...defaultE2EEOptions, ...options.encryption }