Remove all ReadableStream Imports

.changeset/breezy-jars-boil.md

@@ -0,0 +1,5 @@
+---
+'@livekit/rtc-node': patch
+---
+
+Bump '@types/node' pkg version and remove all explicit `ReadableStream` imports

packages/livekit-rtc/package.json

@@ -54,7 +54,7 @@
   },
   "devDependencies": {
     "@napi-rs/cli": "^2.18.0",
-    "@types/node": "^20.9.2",
+    "@types/node": "^22.13.10",
     "prettier": "^3.0.3",
     "tsup": "^8.3.5",
     "typescript": "^5.2.2",

packages/livekit-rtc/src/audio_stream.ts

@@ -1,7 +1,7 @@
 // SPDX-FileCopyrightText: 2024 LiveKit, Inc.
 //
 // SPDX-License-Identifier: Apache-2.0
-import { ReadableStream, type UnderlyingSource } from 'node:stream/web';
+import type { UnderlyingSource } from 'node:stream/web';
 import { AudioFrame } from './audio_frame.js';
 import type { FfiEvent } from './ffi_client.js';
 import { FfiClient, FfiClientEvent, FfiHandle } from './ffi_client.js';

packages/livekit-rtc/src/data_streams/stream_reader.ts

@@ -1,7 +1,6 @@
 // SPDX-FileCopyrightText: 2024 LiveKit, Inc.
 //
 // SPDX-License-Identifier: Apache-2.0
-import type { ReadableStream } from 'node:stream/web';
 import { log } from '../log.js';
 import type { DataStream_Chunk } from '../proto/room_pb.js';
 import { bigIntToNumber } from '../utils.js';

packages/livekit-rtc/src/data_streams/stream_writer.ts

@@ -1,7 +1,6 @@
 // SPDX-FileCopyrightText: 2024 LiveKit, Inc.
 //
 // SPDX-License-Identifier: Apache-2.0
-import type { WritableStream } from 'node:stream/web';
 import type { BaseStreamInfo, ByteStreamInfo, TextStreamInfo } from './types.js';
 
 class BaseStreamWriter<T, InfoType extends BaseStreamInfo> {

packages/livekit-rtc/src/participant.ts

@@ -20,21 +20,29 @@ import {
   ParticipantKind,
 } from './proto/participant_pb.js';
 import {
+  ChatMessage as ChatMessageModel,
   DataStream_ByteHeader,
   DataStream_Chunk,
   DataStream_Header,
   DataStream_OperationType,
   DataStream_TextHeader,
   DataStream_Trailer,
+  EditChatMessageRequest,
+  TranscriptionSegment as ProtoTranscriptionSegment,
   type PublishDataCallback,
+  PublishDataRequest,
   type PublishDataResponse,
   type PublishSipDtmfCallback,
+  PublishSipDtmfRequest,
   type PublishSipDtmfResponse,
   type PublishTrackCallback,
+  PublishTrackRequest,
   type PublishTrackResponse,
   type PublishTranscriptionCallback,
+  PublishTranscriptionRequest,
   type PublishTranscriptionResponse,
   type SendChatMessageCallback,
+  SendChatMessageRequest,
   type SendChatMessageResponse,
   type SendStreamChunkCallback,
   SendStreamChunkRequest,
@@ -46,28 +54,18 @@ import {
   SendStreamTrailerRequest,
   type SendStreamTrailerResponse,
   type SetLocalAttributesCallback,
+  SetLocalAttributesRequest,
   type SetLocalAttributesResponse,
   type SetLocalMetadataCallback,
+  SetLocalMetadataRequest,
   type SetLocalMetadataResponse,
   type SetLocalNameCallback,
+  SetLocalNameRequest,
   type SetLocalNameResponse,
   type TrackPublishOptions,
   type UnpublishTrackCallback,
-  type UnpublishTrackResponse,
-} from './proto/room_pb.js';
-import { ChatMessage as ChatMessageModel } from './proto/room_pb.js';
-import {
-  EditChatMessageRequest,
-  TranscriptionSegment as ProtoTranscriptionSegment,
-  PublishDataRequest,
-  PublishSipDtmfRequest,
-  PublishTrackRequest,
-  PublishTranscriptionRequest,
-  SendChatMessageRequest,
-  SetLocalAttributesRequest,
-  SetLocalMetadataRequest,
-  SetLocalNameRequest,
   UnpublishTrackRequest,
+  type UnpublishTrackResponse,
 } from './proto/room_pb.js';
 import type {
   PerformRpcCallback,
@@ -460,7 +458,7 @@ export class LocalParticipant extends Participant {
     const fileStats = await stat(path);
     const file = await open(path);
     try {
-      const stream: ReadableStream<Uint8Array> = file.readableWebStream({ type: 'bytes' });
+      const stream: ReadableStream<Uint8Array> = file.readableWebStream();
       const streamId = crypto.randomUUID();
       const destinationIdentities = options?.destinationIdentities;
 

packages/livekit-rtc/src/room.ts

@@ -3,7 +3,6 @@
 // SPDX-License-Identifier: Apache-2.0
 import type { TypedEventEmitter as TypedEmitter } from '@livekit/typed-emitter';
 import EventEmitter from 'events';
-import { ReadableStream } from 'node:stream/web';
 import { ByteStreamReader, TextStreamReader } from './data_streams/stream_reader.js';
 import type {
   ByteStreamHandler,

packages/livekit-rtc/src/video_stream.ts

@@ -1,7 +1,7 @@
 // SPDX-FileCopyrightText: 2024 LiveKit, Inc.
 //
 // SPDX-License-Identifier: Apache-2.0
-import { ReadableStream, type UnderlyingSource } from 'node:stream/web';
+import type { UnderlyingSource } from 'node:stream/web';
 import type { FfiEvent } from './ffi_client.js';
 import { FfiClient, FfiClientEvent, FfiHandle } from './ffi_client.js';
 import type { NewVideoStreamResponse, VideoRotation } from './proto/video_frame_pb.js';