Fix

leoaugustov · Feb 14, 2024 · a736d99 · a736d99
1 parent 31ae10d
commit a736d99
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 4 deletions.
diff --git 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
@@ -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,