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

bump sdk

Browse Source
This commit is contained in:
wphan
2023-12-06 07:11:57 -08:00
parent 9ea5505f27
commit 6e90a1d796
5 changed files with 32 additions and 17 deletions
Download Patch File Download Diff File Expand all files Collapse all files

13
src/index.ts
View File

@@ -260,11 +260,16 @@ const main = async () => {
getSlot: () => orderSubscriber.getSlot(),
};
} else {
const userMap = new UserMap(
const userMap = new UserMap({
driftClient,
driftClient.userAccountSubscriptionConfig,
false
);
subscriptionConfig: {
type: 'websocket',
resubTimeoutMs: 30_000,
commitment: stateCommitment,
},
skipInitialLoad: false,
includeIdle: false,
});
dlobProvider = getDLOBProviderFromUserMap(userMap);
}

13
src/publishers/dlobPublisher.ts
View File

@@ -207,11 +207,16 @@ const main = async () => {
getSlot: () => orderSubscriber.getSlot(),
};
} else {
const userMap = new UserMap(
const userMap = new UserMap({
driftClient,
driftClient.userAccountSubscriptionConfig,
false
);
subscriptionConfig: {
type: 'websocket',
resubTimeoutMs: 30_000,
commitment: stateCommitment,
},
skipInitialLoad: false,
includeIdle: false,
});
dlobProvider = getDLOBProviderFromUserMap(userMap);
}

13
src/publishers/tradesPublisher.ts
View File

@@ -94,11 +94,16 @@ const main = async () => {
await slotSubscriber.subscribe();
const userMap = new UserMap(
const userMap = new UserMap({
driftClient,
driftClient.userAccountSubscriptionConfig,
false
);
subscriptionConfig: {
type: 'websocket',
resubTimeoutMs: 30_000,
commitment: stateCommitment,
},
skipInitialLoad: false,
includeIdle: false,
});
await userMap.subscribe();
const redisClient = new RedisClient(REDIS_HOST, REDIS_PORT, REDIS_PASSWORD);