chore: fauxqs bump (#447)

* fauxqs bump

* lock

* Enabling tests for fauxqs

* Remove extended timeout

* Trigger CI

* fauxqs update

Author: CarlosGamero

packages/s3-payload-store/package.json

@@ -41,7 +41,7 @@
         "@lokalise/tsconfig": "^3.0.0",
         "@types/node": "^25.0.2",
         "@vitest/coverage-v8": "^4.0.15",
-        "fauxqs": "^2.0.0",
+        "fauxqs": "^2.7.0",
         "rimraf": "^6.0.1",
         "typescript": "^5.9.3",
         "vitest": "^4.0.15"

packages/sns/package.json

@@ -58,7 +58,7 @@
         "@vitest/coverage-v8": "^4.0.15",
         "awilix": "^13.0.3",
         "awilix-manager": "^6.1.0",
-        "fauxqs": "^2.0.0",
+        "fauxqs": "^2.7.0",
         "ioredis": "^5.7.0",
         "rimraf": "^6.0.1",
         "typescript": "^5.9.3",

packages/sns/test/consumers/SnsSqsPermissionConsumer.subscriptionDeadLetterQueue.spec.ts

@@ -9,8 +9,6 @@ import type { Dependencies } from '../utils/testContext.ts'
 import { registerDependencies } from '../utils/testContext.ts'
 import { SnsSqsPermissionConsumer } from './SnsSqsPermissionConsumer.ts'
 
-const isLocalstack = process.env.QUEUE_BACKEND === 'localstack'
-
 describe('SnsSqsPermissionConsumer - subscription dead letter queue', () => {
   const topicName = 'subscription-dlq-test-topic'
   const queueName = 'subscription-dlq-test-queue'
@@ -108,70 +106,62 @@ describe('SnsSqsPermissionConsumer - subscription dead letter queue', () => {
       expect(subscriptionAttributes.result?.attributes?.RedrivePolicy).toBeUndefined()
     })
 
-    // Real delivery-failure routing depends on the SNS broker honoring the
-    // subscription RedrivePolicy. fauxqs silently drops messages when the
-    // endpoint queue is missing (see fanOutToSubscriptions: `if (!queue) continue`),
-    // so this only runs against LocalStack.
-    it.skipIf(!isLocalstack)(
-      'routes undeliverable messages to the consumer DLQ when the endpoint queue is gone',
-      async () => {
-        consumer = new SnsSqsPermissionConsumer(diContainer.cradle, {
-          creationConfig: {
-            topic: { Name: topicName },
-            queue: { QueueName: queueName },
-          },
-          deadLetterQueue: {
-            redrivePolicy: { maxReceiveCount: 3 },
-            creationConfig: { queue: { QueueName: deadLetterQueueName } },
-          },
-          subscriptionDeadLetterQueue: { reuseConsumerDeadLetterQueue: true },
-        })
-
-        await consumer.init()
-
-        const {
-          topicArn,
-          queueName: sourceQueueName,
-          deadLetterQueueUrl,
-        } = consumer.subscriptionProps
-
-        // Force a delivery failure: delete the endpoint queue while the
-        // subscription stays in place. Subsequent SNS publishes can't reach it,
-        // so the subscription RedrivePolicy should route the message to the DLQ.
-        await testAdmin.deleteQueues(sourceQueueName!)
-
-        await snsClient.send(
-          new PublishCommand({
-            TopicArn: topicArn,
-            Message: JSON.stringify({
-              id: 'sub-dlq-1',
-              messageType: 'remove',
-              timestamp: new Date().toISOString(),
-            }),
+    it('routes undeliverable messages to the consumer DLQ when the endpoint queue is gone', async () => {
+      consumer = new SnsSqsPermissionConsumer(diContainer.cradle, {
+        creationConfig: {
+          topic: { Name: topicName },
+          queue: { QueueName: queueName },
+        },
+        deadLetterQueue: {
+          redrivePolicy: { maxReceiveCount: 3 },
+          creationConfig: { queue: { QueueName: deadLetterQueueName } },
+        },
+        subscriptionDeadLetterQueue: { reuseConsumerDeadLetterQueue: true },
+      })
+
+      await consumer.init()
+
+      const {
+        topicArn,
+        queueName: sourceQueueName,
+        deadLetterQueueUrl,
+      } = consumer.subscriptionProps
+
+      // Force a delivery failure: delete the endpoint queue while the
+      // subscription stays in place. Subsequent SNS publishes can't reach it,
+      // so the subscription RedrivePolicy should route the message to the DLQ.
+      await testAdmin.deleteQueues(sourceQueueName!)
+
+      await snsClient.send(
+        new PublishCommand({
+          TopicArn: topicArn,
+          Message: JSON.stringify({
+            id: 'sub-dlq-1',
+            messageType: 'remove',
+            timestamp: new Date().toISOString(),
           }),
-        )
-
-        let dlqBody: string | undefined
-        const arrived = await waitAndRetry(
-          async () => {
-            const response = await sqsClient.send(
-              new ReceiveMessageCommand({
-                QueueUrl: deadLetterQueueUrl,
-                MaxNumberOfMessages: 1,
-                WaitTimeSeconds: 1,
-              }),
-            )
-            dlqBody = response.Messages?.[0]?.Body
-            return !!dlqBody
-          },
-          500,
-          40,
-        )
-
-        expect(arrived).toBe(true)
-        expect(dlqBody).toContain('sub-dlq-1')
-      },
-      60_000,
-    )
+        }),
+      )
+
+      let dlqBody: string | undefined
+      const arrived = await waitAndRetry(
+        async () => {
+          const response = await sqsClient.send(
+            new ReceiveMessageCommand({
+              QueueUrl: deadLetterQueueUrl,
+              MaxNumberOfMessages: 1,
+              WaitTimeSeconds: 1,
+            }),
+          )
+          dlqBody = response.Messages?.[0]?.Body
+          return !!dlqBody
+        },
+        50,
+        60,
+      )
+
+      expect(arrived).toBe(true)
+      expect(dlqBody).toContain('sub-dlq-1')
+    })
   })
 })

packages/sqs/package.json

@@ -54,7 +54,7 @@
         "@vitest/coverage-v8": "^4.0.15",
         "awilix": "^13.0.3",
         "awilix-manager": "^6.1.0",
-        "fauxqs": "^2.0.0",
+        "fauxqs": "^2.7.0",
         "ioredis": "^5.6.1",
         "rimraf": "^6.0.1",
         "typescript": "^5.9.3",