From 3e00277ee5de6ea5b3249003230ee66c90630d94 Mon Sep 17 00:00:00 2001
From: Lukas deConantsesznak <lukas@lunoho.company>
Date: Wed, 13 Aug 2025 13:45:28 -0600
Subject: [PATCH] feat: use ws v2 subscriber for oracles

---
 src/publishers/dlobPublisher.ts | 4 +++-
 1 file changed, 3 insertions(+), 1 deletion(-)

diff --git a/src/publishers/dlobPublisher.ts b/src/publishers/dlobPublisher.ts
index ffd81de..65cbd2d 100644
--- a/src/publishers/dlobPublisher.ts
+++ b/src/publishers/dlobPublisher.ts
@@ -124,8 +124,9 @@ const WS_FALLBACK_FETCH_INTERVAL = 60_000;
 const KILLSWITCH_SLOT_DIFF_THRESHOLD =
 	parseInt(process.env.KILLSWITCH_SLOT_DIFF_THRESHOLD) || 200;
 
-// TOB monitoring configuration
+// TOB monitoring configuration - defaults to true if not set
 const ENABLE_TOB_MONITORING =
+	!process.env.ENABLE_TOB_MONITORING ||
 	process.env.ENABLE_TOB_MONITORING?.toLowerCase() === 'true';
 const TOB_CHECK_INTERVAL = parseInt(process.env.TOB_CHECK_INTERVAL) || 60_000; // 1 minute
 const TOB_STUCK_THRESHOLD = parseInt(process.env.TOB_STUCK_THRESHOLD) || 60_000; // 1 minute without change
@@ -417,6 +418,7 @@ const main = async () => {
 			resubTimeoutMs: 30_000,
 			logResubMessages: true,
 			perpMarketAccountSubscriber: WebSocketAccountSubscriberV2,
+			oracleAccountSubscriber: WebSocketAccountSubscriberV2,
 		};
 		slotSubscriber = new SlotSubscriber(connection, {
 			resubTimeoutMs: 10_000,