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

only include enabled spot market fulfilments

Browse Source
This commit is contained in:
wphan
2023-12-01 09:13:31 -08:00
parent 8a52e7e7b1
commit 5a04b672ce
1 changed files with 22 additions and 13 deletions
Download Patch File Download Diff File Expand all files Collapse all files

35
src/index.ts
View File

@@ -147,23 +147,32 @@ const initializeAllMarketSubscribers = async (driftClient: DriftClient) => {
};
if (market.phoenixMarket) {
const phoenixSubscriber = getPhoenixSubscriber(
driftClient,
market,
sdkConfig
);
await phoenixSubscriber.subscribe();
markets[market.marketIndex].phoenix = phoenixSubscriber;
const phoenixConfigAccount =
await driftClient.getPhoenixV1FulfillmentConfig(market.phoenixMarket);
if (isVariant(phoenixConfigAccount.status, 'enabled')) {
const phoenixSubscriber = getPhoenixSubscriber(
driftClient,
market,
sdkConfig
);
await phoenixSubscriber.subscribe();
markets[market.marketIndex].phoenix = phoenixSubscriber;
}
}
if (market.serumMarket) {
const serumSubscriber = getSerumSubscriber(
driftClient,
market,
sdkConfig
const serumConfigAccount = await driftClient.getSerumV3FulfillmentConfig(
market.serumMarket
);
await serumSubscriber.subscribe();
markets[market.marketIndex].serum = serumSubscriber;
if (isVariant(serumConfigAccount.status, 'enabled')) {
const serumSubscriber = getSerumSubscriber(
driftClient,
market,
sdkConfig
);
await serumSubscriber.subscribe();
markets[market.marketIndex].serum = serumSubscriber;
}
}
}