hunk.code_window:       throw new PlatformException(message);
       }
       const digestEventsCommand = DigestEventsCommand.create({
         currentJob,
         // backward compatibility - ternary needed to be removed once the queue renewed
         _subscriberId: command._subscriberId ? command._subscriberId : command.subscriberId,
       });
       if (
  
hunk.labels: keep keep keep keep keep replace replace keep keep keep
hunk.after_edit:       _subscriberId: command._subscriberId,
  
hunk.file_path: apps/worker/src/app/workflow/usecases/send-message/digest/digest.usecase.ts
hunk.type: replace
file: import { Controller, Get } from '@nestjs/common';
  import { HealthCheck, HealthCheckResult, HealthCheckService, HttpHealthIndicator } from '@nestjs/terminus';
  import { DalServiceHealthIndicator, WebSocketsQueueServiceHealthIndicator } from '@novu/application-generic';
  
  import { version } from '../../package.json';
  
  @Controller('v1/health-check')
  export class HealthController {
    constructor(
      private healthCheckService: HealthCheckService,
      private dalHealthIndicator: DalServiceHealthIndicator,
      private webSocketsQueueHealthIndicator: WebSocketsQueueServiceHealthIndicator
    ) {}
  
    @Get()
    @HealthCheck()
    async healthCheck(): Promise<HealthCheckResult> {
      const result = await this.healthCheckService.check([
        async () => this.dalHealthIndicator.isHealthy(),
        async () => this.webSocketsQueueHealthIndicator.isHealthy(),
        async () => {
          return {
            apiVersion: {
              version,
              status: 'up',
            },
          };
        },
      ]);
  
      return result;
    }
  }
  