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

configurable cooldown

Browse Source
This commit is contained in:
Nour Alharithi
2024-02-26 10:54:54 -08:00
parent ea4047f7d6
commit 700dc8bde7
1 changed files with 2 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
src/index.ts
View File

@@ -98,6 +98,7 @@ export const ORDERBOOK_UPDATE_INTERVAL = 1000;
const WS_FALLBACK_FETCH_INTERVAL = ORDERBOOK_UPDATE_INTERVAL * 10; const WS_FALLBACK_FETCH_INTERVAL = ORDERBOOK_UPDATE_INTERVAL * 10;
const SLOT_STALENESS_TOLERANCE = const SLOT_STALENESS_TOLERANCE =
parseInt(process.env.SLOT_STALENESS_TOLERANCE) || 20; parseInt(process.env.SLOT_STALENESS_TOLERANCE) || 20;
const ROTATION_COOLDOWN = parseInt(process.env.ROTATION_COOLDOWN) || 5000;
const useWebsocket = process.env.USE_WEBSOCKET?.toLowerCase() === 'true'; const useWebsocket = process.env.USE_WEBSOCKET?.toLowerCase() === 'true';
const rateLimitCallsPerSecond = process.env.RATE_LIMIT_CALLS_PER_SECOND const rateLimitCallsPerSecond = process.env.RATE_LIMIT_CALLS_PER_SECOND
? parseInt(process.env.RATE_LIMIT_CALLS_PER_SECOND) ? parseInt(process.env.RATE_LIMIT_CALLS_PER_SECOND)
@@ -407,7 +408,7 @@ const main = async (): Promise<void> => {
const state = spotMarketRedisMap.get(marketIndex); const state = spotMarketRedisMap.get(marketIndex);
if (state) { if (state) {
const now = Date.now(); const now = Date.now();
if (now - state.lastRotationTime > 30000 && !state.lock) { if (now - state.lastRotationTime > 30500000 && !state.lock) {
state.lastRotationTime = now; state.lastRotationTime = now;
return true; return true;
} }