trade/trade-drift-dlob
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Merge branch 'master' into staging

Browse Source 
merge master
This commit is contained in:
Nour Alharithi
2023-12-12 11:27:41 -08:00
parent 92c1130757 6ee967933f
commit d2ae741d65
2 changed files with 3 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
src/publishers/dlobPublisher.ts
View File

@@ -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}`);

4
src/wsConnectionManager.ts
View File

@@ -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();
}
}