From 61e6854f3061fea08c6dfa18350a80d97ad563fc Mon Sep 17 00:00:00 2001 From: Nour Alharithi Date: Thu, 24 Oct 2024 13:46:47 -0700 Subject: [PATCH] switch over more redis clients to drift common clients --- src/dlob-subscriber/DLOBSubscriberIO.ts | 2 +- src/publishers/dlobPublisher.ts | 2 +- src/publishers/priorityFeesPublisher.ts | 2 +- src/publishers/tradesPublisher.ts | 2 +- src/scripts/publishUnsettledPnlUsers.ts | 7 ++++--- src/serverLite.ts | 2 +- 6 files changed, 9 insertions(+), 8 deletions(-) diff --git a/src/dlob-subscriber/DLOBSubscriberIO.ts b/src/dlob-subscriber/DLOBSubscriberIO.ts index d288dd1..7d8a4aa 100644 --- a/src/dlob-subscriber/DLOBSubscriberIO.ts +++ b/src/dlob-subscriber/DLOBSubscriberIO.ts @@ -9,7 +9,7 @@ import { isOperationPaused, isVariant, } from '@drift-labs/sdk'; -import { RedisClient } from '@drift/common'; +import { RedisClient } from '@drift/common/clients'; import { logger } from '../utils/logger'; import { SubscriberLookup, diff --git a/src/publishers/dlobPublisher.ts b/src/publishers/dlobPublisher.ts index 7e024b9..b79af54 100644 --- a/src/publishers/dlobPublisher.ts +++ b/src/publishers/dlobPublisher.ts @@ -19,7 +19,7 @@ import { SpotMarketConfig, PhoenixSubscriber, } from '@drift-labs/sdk'; -import { RedisClient, RedisClientPrefix } from '@drift/common'; +import { RedisClient, RedisClientPrefix } from '@drift/common/clients'; import { logger, setLogLevel } from '../utils/logger'; import { diff --git a/src/publishers/priorityFeesPublisher.ts b/src/publishers/priorityFeesPublisher.ts index 0b142b6..e53bac6 100644 --- a/src/publishers/priorityFeesPublisher.ts +++ b/src/publishers/priorityFeesPublisher.ts @@ -10,7 +10,7 @@ import { BulkAccountLoader, getMarketsAndOraclesForSubscription, } from '@drift-labs/sdk'; -import { RedisClient, RedisClientPrefix } from '@drift/common'; +import { RedisClient, RedisClientPrefix } from '@drift/common/clients'; import { logger, setLogLevel } from '../utils/logger'; import { sleep } from '../utils/utils'; diff --git a/src/publishers/tradesPublisher.ts b/src/publishers/tradesPublisher.ts index a7a9982..28dab5b 100644 --- a/src/publishers/tradesPublisher.ts +++ b/src/publishers/tradesPublisher.ts @@ -20,7 +20,7 @@ import { OrderActionRecord, Event, } from '@drift-labs/sdk'; -import { RedisClient, RedisClientPrefix } from '@drift/common'; +import { RedisClient, RedisClientPrefix } from '@drift/common/clients'; import { logger, setLogLevel } from '../utils/logger'; import { sleep } from '../utils/utils'; diff --git a/src/scripts/publishUnsettledPnlUsers.ts b/src/scripts/publishUnsettledPnlUsers.ts index d1cac5a..042c829 100644 --- a/src/scripts/publishUnsettledPnlUsers.ts +++ b/src/scripts/publishUnsettledPnlUsers.ts @@ -1,4 +1,5 @@ -import { RedisClient, RedisClientPrefix, sleep } from '@drift/common'; +import { RedisClient, RedisClientPrefix } from '@drift/common/clients'; +import { sleep } from '@drift/common'; import { BigNum, DriftClient, @@ -156,7 +157,7 @@ const writeToDlobRedis = async (userPnlMap: UserPnlMap): Promise => { }; const createMarketPnlLeaderboards = (allPnlUsers: AllPnlUsers): UserPnlMap => { - let pnlMap = {}; + const pnlMap = {}; Object.keys(allPnlUsers).forEach((perpMarketIndex) => { try { @@ -187,7 +188,7 @@ const buildUserMarketLists = ( redisUsers: { user: User; bufferString: string }[], allPnlUsers: AllPnlUsers ): AllPnlUsers => { - let newPnlUsers = allPnlUsers; + const newPnlUsers = allPnlUsers; const usdcSpotMarket = driftClient.getSpotMarketAccount( QUOTE_SPOT_MARKET_INDEX diff --git a/src/serverLite.ts b/src/serverLite.ts index 5ab19af..7d65dbb 100644 --- a/src/serverLite.ts +++ b/src/serverLite.ts @@ -14,7 +14,7 @@ import { MarketType, getVariant, } from '@drift-labs/sdk'; -import { RedisClient, RedisClientPrefix } from '@drift/common'; +import { RedisClient, RedisClientPrefix } from '@drift/common/clients'; import { logger, setLogLevel } from './utils/logger';