diff --git a/packages/server/src/server/session.ts b/packages/server/src/server/session.ts index ac4ea8ac6..8e50221c9 100644 --- a/packages/server/src/server/session.ts +++ b/packages/server/src/server/session.ts @@ -405,7 +405,6 @@ export type SessionOptions = { appVersion: string | null; onMessage: (msg: SessionOutboundMessage) => void; onBinaryMessage?: (frame: Uint8Array) => void; - getBinaryBufferedAmount?: () => number; onLifecycleIntent?: (intent: SessionLifecycleIntent) => void; logger: pino.Logger; downloadTokenStore: DownloadTokenStore; @@ -560,7 +559,6 @@ export class Session { private readonly sessionId: string; private readonly onMessage: (msg: SessionOutboundMessage) => void; private readonly onBinaryMessage: ((frame: Uint8Array) => void) | null; - private readonly getBinaryBufferedAmount: (() => number) | null; private readonly onLifecycleIntent: ((intent: SessionLifecycleIntent) => void) | null; private readonly sessionLogger: pino.Logger; private readonly paseoHome: string; @@ -659,7 +657,6 @@ export class Session { appVersion, onMessage, onBinaryMessage, - getBinaryBufferedAmount, onLifecycleIntent, logger, downloadTokenStore, @@ -689,7 +686,6 @@ export class Session { this.sessionId = uuidv4(); this.onMessage = onMessage; this.onBinaryMessage = onBinaryMessage ?? null; - this.getBinaryBufferedAmount = getBinaryBufferedAmount ?? null; this.onLifecycleIntent = onLifecycleIntent ?? null; this.downloadTokenStore = downloadTokenStore; this.pushTokenStore = pushTokenStore; @@ -8518,11 +8514,4 @@ export class Session { } } - private getCurrentBinaryBufferedAmount(): number { - const bufferedAmount = this.getBinaryBufferedAmount?.() ?? 0; - if (!Number.isFinite(bufferedAmount) || bufferedAmount < 0) { - return 0; - } - return Math.floor(bufferedAmount); - } } diff --git a/packages/server/src/server/websocket-server.ts b/packages/server/src/server/websocket-server.ts index 2a90a7464..5780768e9 100644 --- a/packages/server/src/server/websocket-server.ts +++ b/packages/server/src/server/websocket-server.ts @@ -634,16 +634,6 @@ export class VoiceAssistantWebSocketServer { } this.sendBinaryToConnection(connection, frame); }, - getBinaryBufferedAmount: () => { - if (!connection) { - return 0; - } - let bufferedAmount = 0; - for (const socket of connection.sockets) { - bufferedAmount = Math.max(bufferedAmount, socket.bufferedAmount ?? 0); - } - return bufferedAmount; - }, onLifecycleIntent: (intent) => { this.onLifecycleIntent?.(intent); },