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

fix drift client

Browse Source
This commit is contained in:
Nour Alharithi
2023-11-11 09:37:33 -08:00
parent d18952572a
commit 76d9791ae8
1 changed files with 21 additions and 16 deletions
Download Patch File Download Diff File Expand all files Collapse all files

37
src/index.ts
View File

@@ -166,21 +166,22 @@ const main = async () => {
}); });
const bulkAccountLoader = new BulkAccountLoader( const bulkAccountLoader = new BulkAccountLoader(
connection, connection,
stateCommitment, stateCommitment,
ORDERBOOK_UPDATE_INTERVAL ORDERBOOK_UPDATE_INTERVAL
), );
driftClient = new DriftClient({
connection, driftClient = new DriftClient({
wallet, connection,
programID: clearingHousePublicKey, wallet,
accountSubscription: { programID: clearingHousePublicKey,
type: 'polling', accountSubscription: {
accountLoader: bulkAccountLoader, type: 'polling',
}, accountLoader: bulkAccountLoader,
env: driftEnv, },
userStats: true, env: driftEnv,
}); userStats: true,
});
const dlobCoder = DLOBOrdersCoder.create(); const dlobCoder = DLOBOrdersCoder.create();
const slotSubscriber = new SlotSubscriber(connection, {}); const slotSubscriber = new SlotSubscriber(connection, {});
@@ -213,7 +214,11 @@ const main = async () => {
await userMap.subscribe(); await userMap.subscribe();
const userStatsMap = new UserStatsMap(driftClient, { const userStatsMap = new UserStatsMap(driftClient, {
type: 'polling', type: 'polling',
accountLoader: bulkAccountLoader, accountLoader: new BulkAccountLoader(
connection,
stateCommitment,
ORDERBOOK_UPDATE_INTERVAL * 10
),
}); });
await userStatsMap.subscribe(); await userStatsMap.subscribe();