trade/trade-drift-dlob
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

feat: use ws v2 subscriber for oracles

Browse Source
This commit is contained in:
Lukas deConantsesznak
2025-08-13 13:45:28 -06:00
parent 66f000d2ef
commit 3e00277ee5
1 changed files with 3 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
src/publishers/dlobPublisher.ts
View File

@@ -124,8 +124,9 @@ const WS_FALLBACK_FETCH_INTERVAL = 60_000;
const KILLSWITCH_SLOT_DIFF_THRESHOLD = const KILLSWITCH_SLOT_DIFF_THRESHOLD =
parseInt(process.env.KILLSWITCH_SLOT_DIFF_THRESHOLD) || 200; parseInt(process.env.KILLSWITCH_SLOT_DIFF_THRESHOLD) || 200;
// TOB monitoring configuration // TOB monitoring configuration - defaults to true if not set
const ENABLE_TOB_MONITORING = const ENABLE_TOB_MONITORING =
!process.env.ENABLE_TOB_MONITORING ||
process.env.ENABLE_TOB_MONITORING?.toLowerCase() === 'true'; process.env.ENABLE_TOB_MONITORING?.toLowerCase() === 'true';
const TOB_CHECK_INTERVAL = parseInt(process.env.TOB_CHECK_INTERVAL) || 60_000; // 1 minute 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 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, resubTimeoutMs: 30_000,
logResubMessages: true, logResubMessages: true,
perpMarketAccountSubscriber: WebSocketAccountSubscriberV2, perpMarketAccountSubscriber: WebSocketAccountSubscriberV2,
oracleAccountSubscriber: WebSocketAccountSubscriberV2,
}; };
slotSubscriber = new SlotSubscriber(connection, { slotSubscriber = new SlotSubscriber(connection, {
resubTimeoutMs: 10_000, resubTimeoutMs: 10_000,