From a736d996f5d7501d8ad1355edcd775385ce2a293 Mon Sep 17 00:00:00 2001 From: leoaugustov Date: Wed, 14 Feb 2024 12:01:03 -0300 Subject: [PATCH] Fix --- src/purge-queue.js | 4 +++- test/integration/purge-queue.test.js | 5 ++--- 2 files changed, 5 insertions(+), 4 deletions(-) diff --git a/src/purge-queue.js b/src/purge-queue.js index 004db29..f4a6fb3 100644 --- a/src/purge-queue.js +++ b/src/purge-queue.js @@ -23,5 +23,7 @@ export default async ({ regex: condition, queueUrl, endpointUrl: endpoint }) => return false; }; await consumeMessages(sqsClient, queueUrl, messageConsumer); - logger.success(`Finished purge-queue successfully. ${totalMessagesDeleted} of ${totalMessages} messages were deleted`); + logger.success( + `Finished purge-queue successfully. ${totalMessagesDeleted} of ${totalMessages} messages were deleted` + ); }; diff --git a/test/integration/purge-queue.test.js b/test/integration/purge-queue.test.js index 8101cf5..1cfc617 100644 --- a/test/integration/purge-queue.test.js +++ b/test/integration/purge-queue.test.js @@ -18,11 +18,10 @@ afterAll(async () => { it('should consume messages from queue and delete only those that match the regex', async () => { const queueUrl = getQueueUrl(QUEUE_NAME); - const messages = await sendTestMessages(sqsClient, QUEUE_NAME); - messagesThatShouldBeDeleted = messages.filter(message => message.slice(-1) % 2); - messagesThatShouldBeKept = messages.filter(message => ! message.slice(-1) % 2); + const messagesThatShouldBeDeleted = messages.filter(message => message.slice(-1) % 2); + const messagesThatShouldBeKept = messages.filter(message => ! message.slice(-1) % 2); await purgeQueue({ endpointUrl: SQS_ENDPOINT_URL,