From 5a04b672ce6ee4696cee13c0e4b69da2687995e7 Mon Sep 17 00:00:00 2001
From: wphan <william@drift.trade>
Date: Fri, 1 Dec 2023 09:13:31 -0800
Subject: [PATCH] only include enabled spot market fulfilments

---
 src/index.ts | 35 ++++++++++++++++++++++-------------
 1 file changed, 22 insertions(+), 13 deletions(-)

diff --git a/src/index.ts b/src/index.ts
index f050f5d..b8f14a9 100644
--- a/src/index.ts
+++ b/src/index.ts
@@ -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;
+			}
 		}
 	}