Merge pull request #470 from drift-labs/lukas/dlob-new-ws-subscriber

lukas/dlob new ws subscriber
This commit is contained in:
LukasDeco
2025-07-30 14:01:21 -06:00
committed by GitHub
2 changed files with 4 additions and 6 deletions

View File

@@ -9,7 +9,6 @@ import {
UserMap, UserMap,
Wallet, Wallet,
BulkAccountLoader, BulkAccountLoader,
OrderSubscriber,
SlotSource, SlotSource,
DriftClientSubscriptionConfig, DriftClientSubscriptionConfig,
SlotSubscriber, SlotSubscriber,
@@ -18,10 +17,9 @@ import {
PerpMarketConfig, PerpMarketConfig,
SpotMarketConfig, SpotMarketConfig,
PhoenixSubscriber, PhoenixSubscriber,
MarketType,
OraclePriceData,
ONE,
decodeName, decodeName,
WebSocketAccountSubscriberV2,
ONE,
} from '@drift-labs/sdk'; } from '@drift-labs/sdk';
import { RedisClient, RedisClientPrefix } from '@drift/common/clients'; import { RedisClient, RedisClientPrefix } from '@drift/common/clients';
@@ -29,7 +27,6 @@ import { logger, setLogLevel } from '../utils/logger';
import { import {
SubscriberLookup, SubscriberLookup,
getOpenbookSubscriber, getOpenbookSubscriber,
l2WithBNToStrings,
parsePositiveIntArray, parsePositiveIntArray,
sleep, sleep,
} from '../utils/utils'; } from '../utils/utils';
@@ -391,6 +388,7 @@ const main = async () => {
commitment: stateCommitment, commitment: stateCommitment,
resubTimeoutMs: 30_000, resubTimeoutMs: 30_000,
logResubMessages: true, logResubMessages: true,
accountSubscriber: WebSocketAccountSubscriberV2,
}; };
slotSubscriber = new SlotSubscriber(connection, { slotSubscriber = new SlotSubscriber(connection, {
resubTimeoutMs: 10_000, resubTimeoutMs: 10_000,