Merge remote-tracking branch 'origin/main' into dev

packages/server/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@getpaseo/server",
-  "version": "0.1.51",
+  "version": "0.1.52",
   "description": "Paseo backend server",
   "type": "module",
   "publishConfig": {
@@ -61,8 +61,8 @@
     "@ai-sdk/openai": "2.0.52",
     "@anthropic-ai/claude-agent-sdk": "^0.2.11",
     "@deepgram/sdk": "^3.4.0",
-    "@getpaseo/highlight": "0.1.51",
-    "@getpaseo/relay": "0.1.51",
+    "@getpaseo/highlight": "0.1.52",
+    "@getpaseo/relay": "0.1.52",
     "@isaacs/ttlcache": "^2.1.4",
     "@modelcontextprotocol/sdk": "^1.20.1",
     "@opencode-ai/sdk": "1.2.6",

packages/server/src/server/session.ts

@@ -408,7 +408,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;
@@ -549,7 +548,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;
@@ -661,7 +659,6 @@ export class Session {
       appVersion,
       onMessage,
       onBinaryMessage,
-      getBinaryBufferedAmount,
       onLifecycleIntent,
       logger,
       downloadTokenStore,
@@ -697,7 +694,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;
@@ -8713,11 +8709,4 @@ export class Session {
     }
   }
 
-  private getCurrentBinaryBufferedAmount(): number {
-    const bufferedAmount = this.getBinaryBufferedAmount?.() ?? 0;
-    if (!Number.isFinite(bufferedAmount) || bufferedAmount < 0) {
-      return 0;
-    }
-    return Math.floor(bufferedAmount);
-  }
 }

packages/server/src/server/websocket-server.ts

@@ -673,16 +673,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);
       },