Merge pull request #35 from drift-labs/master
change publisher spot market initializer
This commit is contained in:
@@ -13,6 +13,7 @@ import {
|
||||
SlotSource,
|
||||
DriftClientSubscriptionConfig,
|
||||
SlotSubscriber,
|
||||
isVariant,
|
||||
} from '@drift-labs/sdk';
|
||||
|
||||
import { logger, setLogLevel } from '../utils/logger';
|
||||
@@ -70,6 +71,9 @@ const initializeAllMarketSubscribers = async (driftClient: DriftClient) => {
|
||||
};
|
||||
|
||||
if (market.phoenixMarket) {
|
||||
const phoenixConfigAccount =
|
||||
await driftClient.getPhoenixV1FulfillmentConfig(market.phoenixMarket);
|
||||
if (isVariant(phoenixConfigAccount.status, 'enabled')) {
|
||||
const phoenixSubscriber = getPhoenixSubscriber(
|
||||
driftClient,
|
||||
market,
|
||||
@@ -78,8 +82,13 @@ const initializeAllMarketSubscribers = async (driftClient: DriftClient) => {
|
||||
await phoenixSubscriber.subscribe();
|
||||
markets[market.marketIndex].phoenix = phoenixSubscriber;
|
||||
}
|
||||
}
|
||||
|
||||
if (market.serumMarket) {
|
||||
const serumConfigAccount = await driftClient.getSerumV3FulfillmentConfig(
|
||||
market.serumMarket
|
||||
);
|
||||
if (isVariant(serumConfigAccount.status, 'enabled')) {
|
||||
const serumSubscriber = getSerumSubscriber(
|
||||
driftClient,
|
||||
market,
|
||||
@@ -89,6 +98,7 @@ const initializeAllMarketSubscribers = async (driftClient: DriftClient) => {
|
||||
markets[market.marketIndex].serum = serumSubscriber;
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
return markets;
|
||||
};
|
||||
|
||||
Reference in New Issue
Block a user