test(message): handle various errors when deleting a message

tests/tests/deleting-messages/test00005.test.ts

@@ -0,0 +1,60 @@
+/*
+ * 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 {
+  createQueue,
+  defaultQueue,
+  produceMessage,
+} from '../../common/message-producing-consuming';
+import { getQueueMessages } from '../../common/queue-messages';
+import { delay, promisifyAll } from 'bluebird';
+import { MessageNotFoundError } from '../../../src/lib/message/errors';
+import { Message } from '../../../src/lib/message/message';
+import { getConsumer } from '../../common/consumer';
+
+test('Combined test: Delete a message being in process. Check pending, acknowledged, and dead-letter message. Check queue metrics.', async () => {
+  await createQueue(defaultQueue, false);
+
+  const { queue, messageId } = await produceMessage();
+
+  const queueMessages = await getQueueMessages();
+  const count = await queueMessages.countMessagesByStatusAsync(queue);
+  expect(count.pending).toBe(1);
+  expect(count.acknowledged).toBe(0);
+
+  const consumer = getConsumer({
+    messageHandler: (msg1, cb) => {
+      setTimeout(cb, 20000); // 20s
+    },
+  });
+  await consumer.runAsync();
+
+  await delay(5000);
+
+  const message = promisifyAll(new Message());
+  await expect(async () => {
+    await message.deleteMessageByIdAsync(messageId);
+  }).rejects.toThrow('MESSAGE_IN_PROCESS');
+
+  await delay(20000);
+
+  const count2 = await queueMessages.countMessagesByStatusAsync(queue);
+  expect(count2.pending).toBe(0);
+  expect(count2.acknowledged).toBe(1);
+
+  await message.deleteMessageByIdAsync(messageId);
+
+  const count3 = await queueMessages.countMessagesByStatusAsync(queue);
+  expect(count3.pending).toBe(0);
+  expect(count3.acknowledged).toBe(0);
+
+  await expect(async () => {
+    await message.deleteMessageByIdAsync(messageId);
+  }).rejects.toThrow(MessageNotFoundError);
+});