From 6ee967933fa3c5cfe5588a82a1c142e1e165256a Mon Sep 17 00:00:00 2001 From: Nour Alharithi Date: Tue, 12 Dec 2023 11:27:22 -0800 Subject: [PATCH] fixes --- src/publishers/dlobPublisher.ts | 2 +- src/wsConnectionManager.ts | 4 ++-- 2 files changed, 3 insertions(+), 3 deletions(-) diff --git a/src/publishers/dlobPublisher.ts b/src/publishers/dlobPublisher.ts index 5209823..52aacd9 100644 --- a/src/publishers/dlobPublisher.ts +++ b/src/publishers/dlobPublisher.ts @@ -60,7 +60,7 @@ const useOrderSubscriber = const useGrpc = process.env.USE_GRPC?.toLowerCase() === 'true'; const useWebsocket = process.env.USE_WEBSOCKET?.toLowerCase() === 'true'; -const ORDERBOOK_UPDATE_INTERVAL = useGrpc ? 500 : 1000; +const ORDERBOOK_UPDATE_INTERVAL = 1000; const WS_FALLBACK_FETCH_INTERVAL = 10_000; logger.info(`RPC endpoint: ${endpoint}`); diff --git a/src/wsConnectionManager.ts b/src/wsConnectionManager.ts index 401c6fc..db6d8a2 100644 --- a/src/wsConnectionManager.ts +++ b/src/wsConnectionManager.ts @@ -103,7 +103,7 @@ async function main() { const subscribers = channelSubscribers.get(subscribedChannel); if (subscribers) { subscribers.forEach((ws) => { - if (ws.readyState === WebSocket.OPEN && ws.bufferedAmount < 20) + if (ws.readyState === WebSocket.OPEN && ws.bufferedAmount < 100) ws.send( JSON.stringify({ channel: subscribedChannel, data: message }) ); @@ -288,7 +288,7 @@ async function main() { set = new Set([...set, ...wsSet]); } for (const ws of set) { - if (ws.bufferedAmount > 500) { + if (ws.bufferedAmount > 100) { ws.close(); } }