refactor: run npm run format

Author: 1egoman

examples/rpc/rpc-demo.ts

@@ -96,7 +96,9 @@ const registerReceiverMethods = async (greetersRoom: Room, mathGeniusRoom: Room)
     'exchanging-long-info',
     // eslint-disable-next-line @typescript-eslint/no-unused-vars
     async (data: RpcInvocationData) => {
-      console.log(`[Greeter] ${data.callerIdentity} has arrived and said that its long info is "${data.payload}"`);
+      console.log(
+        `[Greeter] ${data.callerIdentity} has arrived and said that its long info is "${data.payload}"`,
+      );
       await new Promise((resolve) => setTimeout(resolve, 2000));
       return new Array<string>(10_000).fill('Y').join('');
     },
@@ -154,7 +156,7 @@ const performGreeting = async (room: Room): Promise<void> => {
 };
 
 const performSendVeryLongInfo = async (room: Room): Promise<void> => {
-  console.log("[Caller] Sending the greeter a very long message");
+  console.log('[Caller] Sending the greeter a very long message');
   try {
     const response = await room.localParticipant.performRpc({
       destinationIdentity: 'greeter',

src/room/Room.ts

@@ -45,6 +45,7 @@ import type {
 } from '../options';
 import TypedPromise from '../utils/TypedPromise';
 import { getBrowser } from '../utils/browserParser';
+import { CLIENT_PROTOCOL_DEFAULT } from '../version';
 import { BackOffStrategy } from './BackOffStrategy';
 import DeviceManager from './DeviceManager';
 import RTCEngine from './RTCEngine';
@@ -120,7 +121,6 @@ import {
   unpackStreamId,
   unwrapConstraint,
 } from './utils';
-import { CLIENT_PROTOCOL_DEFAULT } from '../version';
 
 export enum ConnectionState {
   Disconnected = 'disconnected',
@@ -2260,9 +2260,9 @@ class Room extends (EventEmitter as new () => TypedEmitter<RoomEventCallbacks>)
     }
   }
 
-  private getRemoteParticipantClientProtocol = (identity: Participant["identity"]) => {
+  private getRemoteParticipantClientProtocol = (identity: Participant['identity']) => {
     return this.remoteParticipants.get(identity)?.clientProtocol ?? CLIENT_PROTOCOL_DEFAULT;
-  }
+  };
 
   private registerRpcDataStreamHandler() {
     this.incomingDataStreamManager.registerByteStreamHandler(

src/room/participant/RemoteParticipant.ts

@@ -5,6 +5,7 @@ import type {
   UpdateTrackSettings,
 } from '@livekit/protocol';
 import type { SignalClient } from '../../api/SignalClient';
+import { CLIENT_PROTOCOL_DEFAULT } from '../../version';
 import { ParticipantEvent, TrackEvent } from '../events';
 import RemoteAudioTrack from '../track/RemoteAudioTrack';
 import type RemoteTrack from '../track/RemoteTrack';
@@ -19,7 +20,6 @@ import type { LoggerOptions } from '../types';
 import { isAudioTrack, isRemoteTrack } from '../utils';
 import Participant, { ParticipantKind } from './Participant';
 import type { ParticipantEventCallbacks } from './Participant';
-import { CLIENT_PROTOCOL_DEFAULT } from '../../version';
 
 export default class RemoteParticipant extends Participant {
   audioTrackPublications: Map<string, RemoteTrackPublication>;

src/room/rpc/RpcClientManager.ts

@@ -1,17 +1,15 @@
 // SPDX-FileCopyrightText: 2026 LiveKit, Inc.
 //
 // SPDX-License-Identifier: Apache-2.0
-import {
-  DataPacket,
-  DataPacket_Kind,
-  RpcRequest,
-} from '@livekit/protocol';
+import { DataPacket, DataPacket_Kind, RpcRequest } from '@livekit/protocol';
 import { type StructuredLogger } from '../../logger';
+import { CLIENT_PROTOCOL_GZIP_RPC } from '../../version';
 import type RTCEngine from '../RTCEngine';
+import type { ByteStreamReader } from '../data-stream/incoming/StreamReader';
 import type OutgoingDataStreamManager from '../data-stream/outgoing/OutgoingDataStreamManager';
+import { EngineEvent } from '../events';
 import type Participant from '../participant/Participant';
 import { Future, compareVersions } from '../utils';
-import type { ByteStreamReader } from '../data-stream/incoming/StreamReader';
 import {
   DATA_STREAM_MIN_BYTES,
   MAX_LEGACY_PAYLOAD_BYTES,
@@ -27,8 +25,6 @@ import {
   gzipDecompress,
   gzipDecompressFromReader,
 } from './utils';
-import { CLIENT_PROTOCOL_GZIP_RPC } from '../../version';
-import { EngineEvent } from '../events';
 
 /**
  * Manages the client (caller) side of RPC: sending requests, tracking pending
@@ -49,7 +45,7 @@ export default class RpcClientManager {
   private pendingResponses = new Map<
     string /* request id */,
     {
-      completionFuture: Future<string, RpcError>,
+      completionFuture: Future<string, RpcError>;
       participantIdentity: string;
     }
   >();
@@ -276,7 +272,9 @@ export default class RpcClientManager {
           }
 
           default: {
-            this.log.warn(`Error handling RPC response data packet: unknown rpcResponse.value.case found (${rpcResponse.value.case})`);
+            this.log.warn(
+              `Error handling RPC response data packet: unknown rpcResponse.value.case found (${rpcResponse.value.case})`,
+            );
             return false;
           }
         }
@@ -303,10 +301,7 @@ export default class RpcClientManager {
    * Handle an incoming byte stream containing an RPC response payload.
    * Decompresses the stream and resolves/rejects the pending data stream future.
    */
-  async handleIncomingDataStream(
-    reader: ByteStreamReader,
-    responseId: string,
-  ) {
+  async handleIncomingDataStream(reader: ByteStreamReader, responseId: string) {
     let decompressedPayload: string;
     try {
       decompressedPayload = await gzipDecompressFromReader(reader);
@@ -347,7 +342,8 @@ export default class RpcClientManager {
       }
     }
 
-    for (const [id, { participantIdentity: pendingIdentity, completionFuture }] of this.pendingResponses) {
+    for (const [id, { participantIdentity: pendingIdentity, completionFuture }] of this
+      .pendingResponses) {
       if (pendingIdentity === participantIdentity) {
         completionFuture.reject?.(RpcError.builtIn('RECIPIENT_DISCONNECTED'));
         this.pendingResponses.delete(id);

src/room/rpc/RpcServerManager.ts

@@ -160,10 +160,7 @@ export default class RpcServerManager {
     // Large response: create the data stream tagged with the request ID,
     // send the RPC response with empty payload, then stream compressed chunks
     // for lower TTFB
-    if (
-      callerClientProtocol >= CLIENT_PROTOCOL_GZIP_RPC &&
-      responseBytes > DATA_STREAM_MIN_BYTES
-    ) {
+    if (callerClientProtocol >= CLIENT_PROTOCOL_GZIP_RPC && responseBytes > DATA_STREAM_MIN_BYTES) {
       const writer = await this.outgoingDataStreamManager.streamBytes({
         topic: RPC_DATA_STREAM_TOPIC,
         destinationIdentities: [callerIdentity],
@@ -205,15 +202,17 @@ export default class RpcServerManager {
    */
   async handleIncomingDataStream(
     reader: ByteStreamReader,
-    callerIdentity: Participant["identity"],
-    dataStreamAttrs: Record<string, string>
+    callerIdentity: Participant['identity'],
+    dataStreamAttrs: Record<string, string>,
   ) {
     const requestId = dataStreamAttrs[RPC_REQUEST_ID_ATTR];
     const method = dataStreamAttrs[RPC_REQUEST_METHOD_ATTR];
     const responseTimeout = parseInt(dataStreamAttrs[RPC_REQUEST_RESPONSE_TIMEOUT_MS_ATTR], 10);
 
     if (!requestId || !method || Number.isNaN(responseTimeout)) {
-      this.log.warn(`RPC data stream malformed: ${RPC_REQUEST_ID_ATTR} / ${RPC_REQUEST_METHOD_ATTR} / ${RPC_REQUEST_RESPONSE_TIMEOUT_MS_ATTR} not set.`);
+      this.log.warn(
+        `RPC data stream malformed: ${RPC_REQUEST_ID_ATTR} / ${RPC_REQUEST_METHOD_ATTR} / ${RPC_REQUEST_RESPONSE_TIMEOUT_MS_ATTR} not set.`,
+      );
       await this.engine.publishRpcResponse(
         callerIdentity,
         requestId,
@@ -277,10 +276,7 @@ export default class RpcServerManager {
 
     const responseBytes = byteLength(response ?? '');
 
-    if (
-      callerClientProtocol >= CLIENT_PROTOCOL_GZIP_RPC &&
-      responseBytes > DATA_STREAM_MIN_BYTES
-    ) {
+    if (callerClientProtocol >= CLIENT_PROTOCOL_GZIP_RPC && responseBytes > DATA_STREAM_MIN_BYTES) {
       // Large response: create the data stream tagged with the request ID,
       // send the RPC response with empty payload, then stream compressed chunks
       // for lower TTFB

src/room/rpc/utils.ts

@@ -261,9 +261,7 @@ export async function gzipDecompress(data: Uint8Array): Promise<string> {
  * into the decompression stream as it arrives rather than buffering first.
  * @internal
  */
-export async function gzipDecompressFromReader(
-  reader: AsyncIterable<Uint8Array>,
-): Promise<string> {
+export async function gzipDecompressFromReader(reader: AsyncIterable<Uint8Array>): Promise<string> {
   const ds = new DecompressionStream('gzip');
   const dsWriter = ds.writable.getWriter();
 

src/version.ts

@@ -7,5 +7,5 @@ export const CLIENT_PROTOCOL_DEFAULT = 0;
 export const CLIENT_PROTOCOL_GZIP_RPC = 1;
 
 /** The client protocol version indicates what level of support that the client has for
-  * client <-> client api interactions. */
+ * client <-> client api interactions. */
 export const clientProtocol = CLIENT_PROTOCOL_GZIP_RPC;