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

revert ws account subscriber

Browse Source
This commit is contained in:
wphan
2025-09-04 13:01:26 -07:00
parent 0f1f6bbb0e
commit 87a7d03d8f
2 changed files with 5 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
src/publishers/dlobPublisher.ts
View File

@@ -17,7 +17,7 @@ import {
PhoenixSubscriber, PhoenixSubscriber,
decodeName, decodeName,
ONE, ONE,
WebSocketDriftClientAccountSubscriberV2, WebSocketAccountSubscriberV2,
} from '@drift-labs/sdk'; } from '@drift-labs/sdk';
import { RedisClient, RedisClientPrefix } from '@drift/common/clients'; import { RedisClient, RedisClientPrefix } from '@drift/common/clients';
@@ -414,7 +414,7 @@ const main = async () => {
commitment: stateCommitment, commitment: stateCommitment,
resubTimeoutMs: 30_000, resubTimeoutMs: 30_000,
logResubMessages: true, logResubMessages: true,
driftClientAccountSubscriber: WebSocketDriftClientAccountSubscriberV2, perpMarketAccountSubscriber: WebSocketAccountSubscriberV2,
}; };
slotSubscriber = new SlotSubscriber(connection, { slotSubscriber = new SlotSubscriber(connection, {
resubTimeoutMs: 10_000, resubTimeoutMs: 10_000,

7
src/scripts/publishUnsettledPnlUsers.ts
View File

@@ -218,10 +218,9 @@ const buildUserMarketLists = (
) )
return []; return [];
const perpPositionWithLpSettle = const perpPositionWithLpSettle = redisUser.user.getPerpPosition(
redisUser.user.getPerpPosition( perpPosition.marketIndex
perpPosition.marketIndex, )[0];
)[0];
const marketPnl = calculateClaimablePnl( const marketPnl = calculateClaimablePnl(
perpMarketAccount, perpMarketAccount,