From b10f3e365585e1b113b1b785afb89f3d043de338 Mon Sep 17 00:00:00 2001
From: Scott Guymer <scott.guymer@philips.com>
Date: Fri, 28 Apr 2023 16:56:28 +0200
Subject: [PATCH] Add config mapping

Signed-off-by: Scott Guymer <scott.guymer@philips.com>
---
 .../events-backend-module-aws-sqs/src/publisher/config.test.ts  | 2 ++
 plugins/events-backend-module-aws-sqs/src/publisher/config.ts   | 2 ++
 2 files changed, 4 insertions(+)

diff --git a/plugins/events-backend-module-aws-sqs/src/publisher/config.test.ts b/plugins/events-backend-module-aws-sqs/src/publisher/config.test.ts
index 1fa9df4ce3..6d7a08d7a7 100644
--- a/plugins/events-backend-module-aws-sqs/src/publisher/config.test.ts
+++ b/plugins/events-backend-module-aws-sqs/src/publisher/config.test.ts
@@ -79,6 +79,7 @@ describe('readConfig', () => {
                     url: 'https://fake1.queue.url',
                     visibilityTimeout: { minutes: 5 },
                     waitTime: { seconds: 10 },
+                    endpoint: 'https://fake.endpoint.url',
                   },
                   timeout: { minutes: 5 },
                   waitTimeAfterEmptyReceive: { seconds: 30 },
@@ -97,6 +98,7 @@ describe('readConfig', () => {
     expect(publisherConfigs[0].topic).toEqual('fake1');
     expect(publisherConfigs[0].region).toEqual('eu-west-1');
     expect(publisherConfigs[0].queueUrl).toEqual('https://fake1.queue.url');
+    expect(publisherConfigs[0].endpoint).toEqual('https://fake.endpoint.url');
     expect(publisherConfigs[0].pollingWaitTime.as('seconds')).toBe(10);
     expect(publisherConfigs[0].timeout.as('seconds')).toBe(300);
     expect(publisherConfigs[0].waitTimeAfterEmptyReceive.as('seconds')).toBe(
diff --git a/plugins/events-backend-module-aws-sqs/src/publisher/config.ts b/plugins/events-backend-module-aws-sqs/src/publisher/config.ts
index 47cd82857c..eeb650ff6c 100644
--- a/plugins/events-backend-module-aws-sqs/src/publisher/config.ts
+++ b/plugins/events-backend-module-aws-sqs/src/publisher/config.ts
@@ -75,6 +75,7 @@ export function readConfig(config: Config): AwsSqsEventSourceConfig[] {
       }
       const queueUrl = topicConfig.getString('queue.url');
       const region = topicConfig.getString('queue.region');
+      const endpoint = topicConfig.getOptionalString('queue.endpoint');
       const visibilityTimeout = readOptionalDuration(
         topicConfig,
         'queue.visibilityTimeout',
@@ -107,6 +108,7 @@ export function readConfig(config: Config): AwsSqsEventSourceConfig[] {
       return {
         pollingWaitTime,
         queueUrl,
+        endpoint,
         region,
         timeout,
         topic,