Propagate NATS connection error to microservice init

worker.module.ts

import { Module, INestMicroservice, Logger } from '@nestjs/common';
import { WorkerService } from './worker.service';
import { WorkerController } from './worker.controller';
import { TypeOrmModule } from '@nestjs/typeorm';
import { NestFactory } from '@nestjs/core';
import { Transport } from '@nestjs/common/enums/transport.enum';

@Module({
  imports: [TypeOrmModule.forRoot()],
  providers: [WorkerService],
  controllers: [WorkerController],
})
export class WorkerModule {
  private static readonly logger = new Logger(WorkerModule.name);

  static async startMicroservice(siteDataWorkerKey: string): Promise<INestMicroservice> {
    const app = await NestFactory.create(WorkerModule);
    const service = WorkerModule.patchNatsMicroservice(app.connectMicroservice({
      transport: Transport.NATS,
      options: {
        url: 'nats://localhost:4222',
        queue: siteDataWorkerKey,
      },
    }));

    await app.startAllMicroservicesAsync();
    await app.init();
    return service;
  }

  private static patchNatsMicroservice(service: INestMicroservice): INestMicroservice {
    const server = (service as any).server;
    server.listen = (callback: (err?: Error) => void) => {
      server.natsClient = server.createNatsClient();
      server.natsClient.once('error', callback);
      server.handleError(server.natsClient);
      server.start(callback);
    };

    return service;
  }

}