From 8b8e3a6a5120bd8f7bc0eacf78f78c7f0a9b152d Mon Sep 17 00:00:00 2001 From: Jon Staab Date: Tue, 28 Oct 2025 08:33:17 -0700 Subject: [PATCH] Reduce socket batch size to prevent ui lockup when using non-wasm event validation --- packages/net/__tests__/policy.test.ts | 2 +- packages/net/src/socket.ts | 6 ++++-- 2 files changed, 5 insertions(+), 3 deletions(-) diff --git a/packages/net/__tests__/policy.test.ts b/packages/net/__tests__/policy.test.ts index b4f222d..f8a5b71 100644 --- a/packages/net/__tests__/policy.test.ts +++ b/packages/net/__tests__/policy.test.ts @@ -281,7 +281,7 @@ describe("policy", () => { expect(closeSpy).toHaveBeenCalled() cleanup() - }, 50000) + }, 100000) it("should reset timer on send activity", () => { const cleanup = socketPolicyCloseInactive(socket) diff --git a/packages/net/src/socket.ts b/packages/net/src/socket.ts index 3526abc..c47272c 100644 --- a/packages/net/src/socket.ts +++ b/packages/net/src/socket.ts @@ -31,6 +31,8 @@ export type SocketEvents = { } export class Socket extends EventEmitter { + static batchSize = 10 + auth: AuthState status = SocketStatus.Closed @@ -44,7 +46,7 @@ export class Socket extends EventEmitter { this.auth = new AuthState(this) this._sendQueue = new TaskQueue({ - batchSize: 50, + batchSize: Socket.batchSize, processItem: (message: ClientMessage) => { this._ws?.send(JSON.stringify(message)) this.emit(SocketEvent.Send, message, this.url) @@ -52,7 +54,7 @@ export class Socket extends EventEmitter { }) this._recvQueue = new TaskQueue({ - batchSize: 50, + batchSize: Socket.batchSize, processItem: (message: RelayMessage) => { this.emit(SocketEvent.Receive, message, this.url) },