diff --git a/docker-compose.yml b/docker-compose.yml index 1d33861b..a89350d7 100644 --- a/docker-compose.yml +++ b/docker-compose.yml @@ -8,7 +8,7 @@ services: - rabbit_data:/var/lib/rabbitmq localstack: - image: localstack/localstack:3.0.2 + image: localstack/localstack:3.2.0 network_mode: bridge hostname: localstack ports: diff --git a/packages/sns/docker-compose.yml b/packages/sns/docker-compose.yml index 8aea6cbf..8ca2d5d6 100644 --- a/packages/sns/docker-compose.yml +++ b/packages/sns/docker-compose.yml @@ -1,6 +1,6 @@ services: localstack: - image: localstack/localstack:3.0.2 + image: localstack/localstack:3.2.0 network_mode: bridge hostname: localstack ports: diff --git a/packages/sns/test/consumers/SnsSqsPermissionsConsumerMultiSchema.spec.ts b/packages/sns/test/consumers/SnsSqsPermissionsConsumerMultiSchema.spec.ts index 23137435..b9c4fbd8 100644 --- a/packages/sns/test/consumers/SnsSqsPermissionsConsumerMultiSchema.spec.ts +++ b/packages/sns/test/consumers/SnsSqsPermissionsConsumerMultiSchema.spec.ts @@ -210,7 +210,7 @@ describe('SNS PermissionsConsumerMultiSchema', () => { updateAttributesIfExists: true, }, deletionConfig: { - deleteIfExists: false, + deleteIfExists: true, }, removeHandlerOverride: async (message, _context, prehandlerOutputs) => { expect(prehandlerOutputs.prehandlerOutput.prehandlerCount).toBe(1) @@ -255,7 +255,7 @@ describe('SNS PermissionsConsumerMultiSchema', () => { updateAttributesIfExists: true, }, deletionConfig: { - deleteIfExists: false, + deleteIfExists: true, }, removeHandlerOverride: async (message, _context, prehandlerOutputs) => { expect(prehandlerOutputs.prehandlerOutput.prehandlerCount).toBe(11) diff --git a/packages/sqs/docker-compose.yml b/packages/sqs/docker-compose.yml index 1f31480a..7e57121a 100644 --- a/packages/sqs/docker-compose.yml +++ b/packages/sqs/docker-compose.yml @@ -1,6 +1,6 @@ services: localstack: - image: localstack/localstack:3.0.2 + image: localstack/localstack:3.2.0 network_mode: bridge hostname: localstack ports: diff --git a/packages/sqs/test/consumers/SqsPermissionsConsumerMonoSchema.errors.spec.ts b/packages/sqs/test/consumers/SqsPermissionsConsumerMonoSchema.errors.spec.ts index 179d866a..ac444729 100644 --- a/packages/sqs/test/consumers/SqsPermissionsConsumerMonoSchema.errors.spec.ts +++ b/packages/sqs/test/consumers/SqsPermissionsConsumerMonoSchema.errors.spec.ts @@ -39,7 +39,7 @@ describe('SqsPermissionsConsumerMonoSchema', () => { QueueUrl: diContainer.cradle.permissionPublisher.queueUrl, }) const reply = await sqsClient.send(command) - expect(reply.Messages!.length).toBe(0) + expect(reply.Messages).toBeUndefined() const fakeErrorResolver = diContainer.cradle .consumerErrorResolver as FakeConsumerErrorResolver diff --git a/packages/sqs/test/consumers/SqsPermissionsConsumerMonoSchema.spec.ts b/packages/sqs/test/consumers/SqsPermissionsConsumerMonoSchema.spec.ts index 2eb4e633..85bb9792 100644 --- a/packages/sqs/test/consumers/SqsPermissionsConsumerMonoSchema.spec.ts +++ b/packages/sqs/test/consumers/SqsPermissionsConsumerMonoSchema.spec.ts @@ -100,7 +100,7 @@ describe('SqsPermissionsConsumerMonoSchema', () => { QueueUrl: diContainer.cradle.permissionPublisher.queueUrl, }) const reply = await sqsClient.send(command) - expect(reply.Messages!.length).toBe(0) + expect(reply.Messages).toBeUndefined() const fakeErrorResolver = diContainer.cradle .consumerErrorResolver as FakeConsumerErrorResolver diff --git a/packages/sqs/test/consumers/SqsPermissionsConsumerMultiSchema.spec.ts b/packages/sqs/test/consumers/SqsPermissionsConsumerMultiSchema.spec.ts index 3d2017b5..567e48d1 100644 --- a/packages/sqs/test/consumers/SqsPermissionsConsumerMultiSchema.spec.ts +++ b/packages/sqs/test/consumers/SqsPermissionsConsumerMultiSchema.spec.ts @@ -415,7 +415,7 @@ describe('SqsPermissionsConsumerMultiSchema', () => { QueueUrl: publisher.queueUrl, }) const reply = await sqsClient.send(command) - expect(reply.Messages!.length).toBe(0) + expect(reply.Messages).toBeUndefined() const fakeErrorResolver = diContainer.cradle .consumerErrorResolver as FakeConsumerErrorResolver