diff --git a/src/index.ts b/src/index.ts index d68990a..b117104 100644 --- a/src/index.ts +++ b/src/index.ts @@ -168,7 +168,16 @@ const initializeAllMarketSubscribers = async (driftClient: DriftClient) => { sdkConfig ); await phoenixSubscriber.subscribe(); - markets[market.marketIndex].phoenix = phoenixSubscriber; + // Test get L2 to know if we should add + try { + phoenixSubscriber.getL2Asks(); + phoenixSubscriber.getL2Bids(); + markets[market.marketIndex].phoenix = phoenixSubscriber; + } catch (e) { + logger.info( + `Excluding phoenix for ${market.marketIndex}, error: ${e}` + ); + } } } @@ -183,7 +192,15 @@ const initializeAllMarketSubscribers = async (driftClient: DriftClient) => { sdkConfig ); await serumSubscriber.subscribe(); - markets[market.marketIndex].serum = serumSubscriber; + try { + serumSubscriber.getL2Asks(); + serumSubscriber.getL2Bids(); + markets[market.marketIndex].serum = serumSubscriber; + } catch (e) { + logger.info( + `Excluding phoenix for ${market.marketIndex}, error: ${e}` + ); + } } } } diff --git a/src/publishers/dlobPublisher.ts b/src/publishers/dlobPublisher.ts index 52aacd9..ae6dca0 100644 --- a/src/publishers/dlobPublisher.ts +++ b/src/publishers/dlobPublisher.ts @@ -89,7 +89,16 @@ const initializeAllMarketSubscribers = async (driftClient: DriftClient) => { sdkConfig ); await phoenixSubscriber.subscribe(); - markets[market.marketIndex].phoenix = phoenixSubscriber; + // Test get L2 to know if we should add + try { + phoenixSubscriber.getL2Asks(); + phoenixSubscriber.getL2Bids(); + markets[market.marketIndex].phoenix = phoenixSubscriber; + } catch (e) { + logger.info( + `Excluding phoenix for ${market.marketIndex}, error: ${e}` + ); + } } } @@ -104,7 +113,15 @@ const initializeAllMarketSubscribers = async (driftClient: DriftClient) => { sdkConfig ); await serumSubscriber.subscribe(); - markets[market.marketIndex].serum = serumSubscriber; + try { + serumSubscriber.getL2Asks(); + serumSubscriber.getL2Bids(); + markets[market.marketIndex].serum = serumSubscriber; + } catch (e) { + logger.info( + `Excluding phoenix for ${market.marketIndex}, error: ${e}` + ); + } } } }