From ecb77926a4681e45592b617e90653f56b86a7367 Mon Sep 17 00:00:00 2001 From: Ricardo Espinoza Date: Thu, 15 Oct 2020 17:23:38 -0400 Subject: [PATCH] :bug: AWS SNS Trigger bug #1058 (#1064) --- packages/nodes-base/nodes/Aws/AwsSnsTrigger.node.ts | 11 ++++++++--- 1 file changed, 8 insertions(+), 3 deletions(-) diff --git a/packages/nodes-base/nodes/Aws/AwsSnsTrigger.node.ts b/packages/nodes-base/nodes/Aws/AwsSnsTrigger.node.ts index 42981f315f2..745cbe0fcc9 100644 --- a/packages/nodes-base/nodes/Aws/AwsSnsTrigger.node.ts +++ b/packages/nodes-base/nodes/Aws/AwsSnsTrigger.node.ts @@ -15,7 +15,9 @@ import { awsApiRequestSOAP, } from './GenericFunctions'; -import { get } from 'lodash'; +import { + get, +} from 'lodash'; export class AwsSnsTrigger implements INodeType { description: INodeTypeDescription = { @@ -36,7 +38,7 @@ export class AwsSnsTrigger implements INodeType { { name: 'aws', required: true, - } + }, ], webhooks: [ { @@ -108,7 +110,10 @@ export class AwsSnsTrigger implements INodeType { 'Version=2010-03-31', ]; const data = await awsApiRequestSOAP.call(this, 'sns', 'GET', '/?Action=ListSubscriptionsByTopic&' + params.join('&')); - const subscriptions = get(data, 'ListSubscriptionsByTopicResponse.ListSubscriptionsByTopicResult.Subscriptions.member'); + let subscriptions = get(data, 'ListSubscriptionsByTopicResponse.ListSubscriptionsByTopicResult.Subscriptions.member'); + if (!Array.isArray(subscriptions)) { + subscriptions = [subscriptions]; + } for (const subscription of subscriptions) { if (webhookData.webhookId === subscription.SubscriptionArn) { return true;