Merge pull request #471 from drift-labs/patch/ws-subscriber-v2
patch/ws subscriber v2
This commit is contained in:
Submodule drift-common updated: 55975ac61a...8f94c374ad
@@ -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,
|
||||||
|
|||||||
Reference in New Issue
Block a user