nest-bull.e2e-spec.ts

import { BullModule, getQueueToken } from '../lib';
import { Queue } from 'bull';
import { Test, TestingModule } from '@nestjs/testing';

describe('BullModule', () => {
  let module: TestingModule;
  const fakeProcessor = jest.fn();
  beforeAll(async () => {
    module = await Test.createTestingModule({
      imports: [
        BullModule.forRoot({
          name: 'test',
          processors: [fakeProcessor],
        }),
      ],
    }).compile();
  });
  it('should process jobs with the given processors', async () => {
    const queue: Queue = module.get<Queue>(getQueueToken('test'));
    await queue.add(null);
    return new Promise(resolve => {
      setTimeout(() => {
        expect(fakeProcessor).toHaveBeenCalledTimes(1);
        resolve();
      }, 100);
    });
  });
});