Hey folks - how can I use SST to setup email sendi...
# helpt
Tharshan
11/15/2021, 11:49 AMHey folks - how can I use SST to setup email sending via AWS in the stack?
m
manitej
11/15/2021, 11:50 AMUse AWS SES
t
Tharshan
11/15/2021, 11:51 AM@manitej ok gotcha. Do we have to configure that manually within AWS console? I was asking if there is a way to do it with IaC within SST stacks
m
manitej
11/15/2021, 11:53 AMTo grant all ur API endpoints permission to SES, change
const api = new sst.Api(this, "Api", {
routes: {
"POST /": "src/lambda.handler",
},
});
to
const api = new sst.Api(this, "Api", {
permissions: ["ses"],
routes: {
"POST /": "src/lambda.handler",
},
});
manitej
11/15/2021, 11:55 AMUse
aws-cdkt
Tharshan
11/15/2021, 1:35 PMWhen I apply that permissions change
Tharshan
11/15/2021, 1:35 PMit says no change detected
Tharshan
11/15/2021, 1:35 PMIs that normal?
f
Frank
11/15/2021, 5:20 PM
Thanks for chiming in @manitej
Frank
11/15/2021, 5:21 PM
@Tharshan give this a try:
Copy code
const api = new sst.Api(this, "Api", {
defaultFunctionProps: {
permissions: ["ses"],
}
routes: {
"POST /": "src/lambda.handler",
},
});Frank
11/15/2021, 5:21 PM
I also had to add the sender addresses in SES, and validate them.
Frank
11/15/2021, 5:22 PM
I did it manually a long while back. Not sure if you can do that automatically in CloudFormation these days.
t
Tharshan
11/15/2021, 5:29 PMHey @Frank - yep I got it to work well.
Since I am sending notifications via different services like webhooks, email (ses) and slack - I am trying to switch to SNS
To get a fanout pattern - so it sends to each consumer
Tharshan
11/15/2021, 5:30 PMThe consumer gets a message like so
Receipt sent! {Records: [{EventSource: 'aws:sns',EventVersion: '1.0',EventSubscriptionArn: 'arn:aws:sns:us-west-2:132730161483:dev-slack-feedback-widget-NotifyTopic:3e80d4df-78f4-40e8-ba5b-3b415ee0cf8d',Sns: [Object]}]}Tharshan
11/15/2021, 5:30 PMBut i don’t see the message I published to the topic
Tharshan
11/15/2021, 5:30 PM Copy code
const topicPayload = {
default: JSON.stringify(payload),
};
await sns
.publish({
TopicArn: process.env.topicArn,
Message: JSON.stringify(topicPayload),
MessageStructure: "json",
})
.promise();Tharshan
11/15/2021, 5:32 PMUnless this is possible with SQS too?
f
Frank
11/15/2021, 5:33 PM
The consumer gets a message like soWhat consumer is this, Queue or Kinesis Stream?
t
Tharshan
11/15/2021, 5:35 PMIt’s a Topic construct
Tharshan
11/15/2021, 5:35 PM Copy code
const topic = new sst.Topic(this, "NotifyTopic", {
subscribers: [
"src/lambda/consumers/email.main",
"src/lambda/consumers/webhook.main",
"src/lambda/consumers/zapier.main",
"src/lambda/consumers/slack.main",
],
});Tharshan
11/15/2021, 5:35 PMAh I see the message is actually inside the Sns key
f
Frank
11/15/2021, 5:35 PM
ah yeah
t
Tharshan
11/15/2021, 5:35 PMStrange that it always give me an array of records
Tharshan
11/15/2021, 5:36 PMIs there a way to only get it to give me one object?
f
Frank
11/15/2021, 5:40 PM
yeah it’s always an array
t
Tharshan
11/15/2021, 5:45 PMAh Ok - so I should expect to always process them as an array cause there maybe more than one?
f
Frank
11/15/2021, 6:03 PM
yeah, you will always receive an array, I just loop through them