web/backend/tests/flows/queue.integration.test.ts

import { describe, it, expect, beforeEach, afterEach, vi } from 'vitest';

// bypass mocks
vi.unmock('ioredis');

import { Queue, Worker } from 'bullmq';
import Redis from 'ioredis';

describe('BullMQ Infrastructure Engine Integration', () => {
  let connection: Redis;
  let testQueue: Queue;
  let testWorker: Worker;

  beforeEach(() => {
    // configure Redis
    connection = new Redis(process.env.REDIS_URL || 'redis://127.0.0.1:6379', {
      maxRetriesPerRequest: null,
    });
    testQueue = new Queue('test_downloads', { connection });
  });

  afterEach(async () => {
    if (testWorker) await testWorker.close();
    if (testQueue) await testQueue.close();
    if (connection) {
      await connection.flushdb();
      await connection.quit();
    }
  });

  it('Should successfully dispatch, pick up, and drain tasks via the localized pipeline', async () => {
    const jobPromise = new Promise<void>((resolve) => {
      testWorker = new Worker(
        'test_downloads',
        (job) => {
          expect(job.data.weight).toBe(1);
          resolve();
        },
        { connection }
      );
    });

    await testQueue.add('lock', { weight: 1 });
    await expect(jobPromise).resolves.not.toThrow();
  });
});