From d24d7e57de686d9e9065b1f43633cc04a1e86421 Mon Sep 17 00:00:00 2001 From: Igor Savin Date: Tue, 12 Mar 2024 11:43:43 +0200 Subject: [PATCH 1/2] Update localstack --- docker-compose.yml | 2 +- packages/sns/docker-compose.yml | 2 +- packages/sqs/docker-compose.yml | 2 +- 3 files changed, 3 insertions(+), 3 deletions(-) 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/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: From 5881fc91ea5fe85b07cfb8aea822013c3b286641 Mon Sep 17 00:00:00 2001 From: Igor Savin Date: Tue, 12 Mar 2024 11:57:38 +0200 Subject: [PATCH 2/2] Fix tests --- .../consumers/SnsSqsPermissionsConsumerMultiSchema.spec.ts | 4 ++-- .../consumers/SqsPermissionsConsumerMonoSchema.errors.spec.ts | 2 +- .../test/consumers/SqsPermissionsConsumerMonoSchema.spec.ts | 2 +- .../test/consumers/SqsPermissionsConsumerMultiSchema.spec.ts | 2 +- 4 files changed, 5 insertions(+), 5 deletions(-) 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/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