diff --git a/drift-common b/drift-common index 80500ff..5797c05 160000 --- a/drift-common +++ b/drift-common @@ -1 +1 @@ -Subproject commit 80500ff2eb88438aeebb8ea1e9c8ba78176013c8 +Subproject commit 5797c05073274e5a57ccc636f3b09cab2bc980c7 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,