From 87a7d03d8f92e3063d42ade6bce43ebd46baf41d Mon Sep 17 00:00:00 2001 From: wphan Date: Thu, 4 Sep 2025 13:01:26 -0700 Subject: [PATCH] revert ws account subscriber --- src/publishers/dlobPublisher.ts | 4 ++-- src/scripts/publishUnsettledPnlUsers.ts | 7 +++---- 2 files changed, 5 insertions(+), 6 deletions(-) diff --git a/src/publishers/dlobPublisher.ts b/src/publishers/dlobPublisher.ts index d21b871..fba9e8b 100644 --- a/src/publishers/dlobPublisher.ts +++ b/src/publishers/dlobPublisher.ts @@ -17,7 +17,7 @@ import { PhoenixSubscriber, decodeName, ONE, - WebSocketDriftClientAccountSubscriberV2, + WebSocketAccountSubscriberV2, } from '@drift-labs/sdk'; import { RedisClient, RedisClientPrefix } from '@drift/common/clients'; @@ -414,7 +414,7 @@ const main = async () => { commitment: stateCommitment, resubTimeoutMs: 30_000, logResubMessages: true, - driftClientAccountSubscriber: WebSocketDriftClientAccountSubscriberV2, + perpMarketAccountSubscriber: WebSocketAccountSubscriberV2, }; slotSubscriber = new SlotSubscriber(connection, { resubTimeoutMs: 10_000, diff --git a/src/scripts/publishUnsettledPnlUsers.ts b/src/scripts/publishUnsettledPnlUsers.ts index b92e348..5932b46 100644 --- a/src/scripts/publishUnsettledPnlUsers.ts +++ b/src/scripts/publishUnsettledPnlUsers.ts @@ -218,10 +218,9 @@ const buildUserMarketLists = ( ) return []; - const perpPositionWithLpSettle = - redisUser.user.getPerpPosition( - perpPosition.marketIndex, - )[0]; + const perpPositionWithLpSettle = redisUser.user.getPerpPosition( + perpPosition.marketIndex + )[0]; const marketPnl = calculateClaimablePnl( perpMarketAccount,