1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
|
// spellchecker:words sesv2 amazonses
import {
SendEmailCommand,
SESv2Client,
SESv2ClientConfig,
} from "@aws-sdk/client-sesv2";
import { Logger } from "@crupest/base/log";
import { Mail, MailDeliverContext, SyncMailDeliverer } from "../mail.ts";
declare module "../mail.ts" {
interface MailDeliverResult {
awsMessageId?: string;
}
}
export class AwsMailDeliverer extends SyncMailDeliverer {
readonly name = "aws";
readonly #logger;
readonly #aws;
readonly #ses;
constructor(logger: Logger, aws: SESv2ClientConfig) {
super(logger);
this.#logger = logger;
this.#aws = aws;
this.#ses = new SESv2Client(aws);
}
protected override async doDeliver(
mail: Mail,
context: MailDeliverContext,
): Promise<void> {
this.#logger.info("Begin to call aws send-email api...");
try {
const sendCommand = new SendEmailCommand({
Content: {
Raw: { Data: mail.toUtf8Bytes() },
},
});
const res = await this.#ses.send(sendCommand);
if (res.MessageId == null) {
this.#logger.warn("Aws send-email returns no message id.");
} else {
context.result.awsMessageId = `${res.MessageId}@${this.#aws.region}.amazonses.com`;
}
context.result.recipients.set("*", {
kind: "done",
message: `Successfully called aws send-email, message id ${context.result.awsMessageId}.`,
});
} catch (cause) {
context.result.recipients.set("*", {
kind: "fail",
message: "An error was thrown when calling aws send-email." + cause,
cause,
});
}
}
}
|
