mudhorn/n8n
1
0
Fork 0
mirror of https://github.com/n8n-io/n8n.git synced 2025-01-12 21:37:32 -08:00
Code Issues Actions Packages Projects Releases Wiki Activity

⚡ Additional fix to AWS SNS Trigger

Browse source
This commit is contained in:
Jan Oberhauser 2020-10-15 23:23:54 +02:00
parent ecb77926a4
commit b40dec3e4a
1 changed files with 11 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

15
packages/nodes-base/nodes/Aws/AwsSnsTrigger.node.ts
View file

@ -110,11 +110,18 @@ export class AwsSnsTrigger implements INodeType {
'Version=2010-03-31', 'Version=2010-03-31',
]; ];
const data = await awsApiRequestSOAP.call(this, 'sns', 'GET', '/?Action=ListSubscriptionsByTopic&' + params.join('&')); const data = await awsApiRequestSOAP.call(this, 'sns', 'GET', '/?Action=ListSubscriptionsByTopic&' + params.join('&'));
let subscriptions = get(data, 'ListSubscriptionsByTopicResponse.ListSubscriptionsByTopicResult.Subscriptions.member'); const subscriptions = get(data, 'ListSubscriptionsByTopicResponse.ListSubscriptionsByTopicResult.Subscriptions');
if (!Array.isArray(subscriptions)) { if (!subscriptions || !subscriptions.member) {
subscriptions = [subscriptions]; return false;
} }
for (const subscription of subscriptions) {
let subscriptionMembers = subscriptions.member;
if (!Array.isArray(subscriptionMembers)) {
subscriptionMembers = [subscriptionMembers];
}
for (const subscription of subscriptionMembers) {
if (webhookData.webhookId === subscription.SubscriptionArn) { if (webhookData.webhookId === subscription.SubscriptionArn) {
return true; return true;
} }