diff --git a/src/core/healthCheck.ts b/src/core/healthCheck.ts index 1761524..fd54f48 100644 --- a/src/core/healthCheck.ts +++ b/src/core/healthCheck.ts @@ -46,6 +46,14 @@ function evaluateHealth(currentSlot: number): { return { isHealthy: true }; } + const currentHealthStatus = getHealthStatus(); + if (currentHealthStatus !== HEALTH_STATUS.Ok) { + return { + isHealthy: false, + reason: `Unhealthy state: ${currentHealthStatus}`, + }; + } + const timeDelta = now - globalHealthState.lastSlotTimestamp; const slotDelta = currentSlot - globalHealthState.lastSlot; diff --git a/src/publishers/dlobPublisher.ts b/src/publishers/dlobPublisher.ts index 1560d78..c2bad22 100644 --- a/src/publishers/dlobPublisher.ts +++ b/src/publishers/dlobPublisher.ts @@ -128,7 +128,9 @@ const SPOT_MARKETS_TO_LOAD = : undefined; const enableOffloadQueue = process.env.ENABLE_OFFLOAD === 'true'; -const ignoreList = process.env.IGNORE_LIST?.split(',') || ['5N1AcdftujhXWZdBaqfciaKtXn6uVBKjmgwf6aQxR1vW']; +const ignoreList = process.env.IGNORE_LIST?.split(',') || [ + '5N1AcdftujhXWZdBaqfciaKtXn6uVBKjmgwf6aQxR1vW', +]; logger.info(`RPC endpoint: ${endpoint}`); logger.info(`WS endpoint: ${wsEndpoint}`); @@ -479,7 +481,7 @@ const main = async () => { const orderSubscriber = new OrderSubscriberFiltered({ driftClient, subscriptionConfig, - ignoreList + ignoreList, }); dlobProvider = getDLOBProviderFromOrderSubscriber(orderSubscriber);