test00007.test.ts

/*
 * Copyright (c)
 * Weyoss <weyoss@protonmail.com>
 * https://github.com/weyoss
 *
 * This source code is licensed under the MIT license found in the LICENSE file
 * in the root directory of this source tree.
 */

import { expect, test } from '@jest/globals';
import bluebird from 'bluebird';
import { RedisKeysError } from '../../../src/common/redis-keys/redis-keys.error.js';
import {
  Consumer,
  ConsumerGroups,
  EQueueDeliveryModel,
  EQueueType,
  IQueueParams,
} from '../../../src/lib/index.js';
import { getQueue } from '../../common/queue.js';

test('Consumer group ID validation', async () => {
  const queue1: IQueueParams = {
    name: 'test-queue',
    ns: 'ns1',
  };

  const queue = await getQueue();
  await queue.saveAsync(
    queue1,
    EQueueType.PRIORITY_QUEUE,
    EQueueDeliveryModel.PUB_SUB,
  );

  const consumer1 = bluebird.promisifyAll(new Consumer());
  await expect(
    consumer1.consumeAsync(
      { queue: queue1, groupId: 'my-group-1!' },
      (msg, cb) => cb(),
    ),
  ).rejects.toThrow(RedisKeysError);

  const consumerGroups = bluebird.promisifyAll(new ConsumerGroups());
  await expect(
    consumerGroups.saveConsumerGroupAsync(queue1, 'my-group-1!'),
  ).rejects.toThrow(RedisKeysError);

  await consumerGroups.shutdownAsync();
  await consumer1.shutdownAsync();
});