fix(sns): add region parameter to helper functions

EndemolShineGroup · Nov 10, 2018 · 308369e · 308369e
1 parent 62785e6
commit 308369e
Show file tree

Hide file tree

Showing 3 changed files with 10 additions and 6 deletions.
diff --git a/src/aws/sns/createSnsTopic.ts b/src/aws/sns/createSnsTopic.ts
@@ -1,7 +1,7 @@
 import AWS from 'aws-sdk';
 
-export default async (topicName: string) => {
-  const sns = new AWS.SNS();
+export default async (topicName: string, region = 'us-east-1') => {
+  const sns = new AWS.SNS({ region });
 
   const params = {
     Name: topicName,

diff --git a/src/aws/sns/publishSnsMessage.ts b/src/aws/sns/publishSnsMessage.ts
@@ -1,7 +1,11 @@
 import AWS from 'aws-sdk';
 
-export default async (topicName: string, message: string) => {
-  const sns = new AWS.SNS();
+export default async (
+  topicName: string,
+  message: string,
+  region = 'us-east-1',
+) => {
+  const sns = new AWS.SNS({ region });
 
   const listTopicsResponse = await sns.listTopics().promise();
 

diff --git a/src/aws/sns/removeSnsTopic.ts b/src/aws/sns/removeSnsTopic.ts
@@ -1,7 +1,7 @@
 import AWS from 'aws-sdk';
 
-export default async (topicName: string) => {
-  const sns = new AWS.SNS();
+export default async (topicName: string, region = 'us-east-1') => {
+  const sns = new AWS.SNS({ region });
 
   const listTopicsResponse = await sns.listTopics().promise();
   if (!listTopicsResponse || !listTopicsResponse.Topics) {