diff --git a/src/core/metrics.ts b/src/core/metrics.ts index 13d03d5..bd6b883 100644 --- a/src/core/metrics.ts +++ b/src/core/metrics.ts @@ -181,7 +181,7 @@ export const setHealthStatus = (status: HEALTH_STATUS): void => { * We may be hit by multiple sources performing health checks on us, so this middleware will latch * to its health state and only update every `healthCheckInterval`. * - * A grace period is also used to only report unhealthy if we have been unhealthy beyond the grace period. + * A grace period is also used to report unhealthy only if we have been unhealthy beyond the grace period. */ const handleHealthCheck = ( healthCheckGracePeriod: number, @@ -226,14 +226,14 @@ const handleHealthCheck = ( lastHealthCheckPerformed = Date.now(); if (!lastHealthCheckState && !inGracePeriod) { - healthStatus = HEALTH_STATUS.UnhealthySlotSubscriber; + setHealthStatus(HEALTH_STATUS.UnhealthySlotSubscriber); res.writeHead(500); res.end(`NOK`); return; } - healthStatus = HEALTH_STATUS.Ok; + setHealthStatus(HEALTH_STATUS.Ok); res.writeHead(200); res.end('OK'); }; diff --git a/src/dlob-subscriber/DLOBSubscriberIO.ts b/src/dlob-subscriber/DLOBSubscriberIO.ts index b5bf77a..0a603f9 100644 --- a/src/dlob-subscriber/DLOBSubscriberIO.ts +++ b/src/dlob-subscriber/DLOBSubscriberIO.ts @@ -238,7 +238,7 @@ export class DLOBSubscriberIO extends DLOBSubscriber { Date.now() - lastMarketSlotAndTime.ts > MAKRET_STALENESS_THRESHOLD && !skipSlotCheck ) { - console.log( + logger.warn( `Unhealthy process due to same slot for market ${marketName} after > ${MAKRET_STALENESS_THRESHOLD}ms. dlobProviderSlot: ${slot}, marketSlot: ${l2Formatted['marketSlot']}` ); setHealthStatus(HEALTH_STATUS.Restart); @@ -246,7 +246,7 @@ export class DLOBSubscriberIO extends DLOBSubscriber { lastMarketSlotAndTime && l2Formatted['marketSlot'] !== lastMarketSlotAndTime.slot ) { - console.log( + logger.warn( `Updating market slot for ${marketArgs.marketName} with slot ${l2Formatted['marketSlot']}` ); this.lastMarketSlotMap