diff options
author | Yuqian Yang <crupest@crupest.life> | 2025-04-30 00:20:23 +0800 |
---|---|---|
committer | Yuqian Yang <crupest@crupest.life> | 2025-05-04 19:15:31 +0800 |
commit | 690f9f843324c359a46bcb8b51b5563e2bec800a (patch) | |
tree | fb17ed2aac5cbd5335b5e819ee9b1a8786c0d6de /services/docker/mail-server/aws-sendmail/aws/deliver.ts | |
parent | ee338238805953b505459eac09aa07610865ebf6 (diff) | |
download | crupest-690f9f843324c359a46bcb8b51b5563e2bec800a.tar.gz crupest-690f9f843324c359a46bcb8b51b5563e2bec800a.tar.bz2 crupest-690f9f843324c359a46bcb8b51b5563e2bec800a.zip |
HALF WORK!: 2025-5-4
Diffstat (limited to 'services/docker/mail-server/aws-sendmail/aws/deliver.ts')
-rw-r--r-- | services/docker/mail-server/aws-sendmail/aws/deliver.ts | 42 |
1 files changed, 42 insertions, 0 deletions
diff --git a/services/docker/mail-server/aws-sendmail/aws/deliver.ts b/services/docker/mail-server/aws-sendmail/aws/deliver.ts new file mode 100644 index 0000000..bdc9584 --- /dev/null +++ b/services/docker/mail-server/aws-sendmail/aws/deliver.ts @@ -0,0 +1,42 @@ +import { SendEmailCommand, SESv2Client } from "@aws-sdk/client-sesv2"; + +import { AwsContext } from "./base.ts"; +import { Mail, MailDeliverer } from "../mail.ts"; + +export class AwsMailDeliverer extends MailDeliverer { + private _ses; + + constructor(readonly aws: AwsContext) { + super("aws"); + + const { region, credentials } = aws; + + this._ses = new SESv2Client({ region, credentials }); + } + + protected override async doDeliver(mail: Mail): Promise<void> { + let awsMessageId: string | undefined; + + try { + const sendCommand = new SendEmailCommand({ + Content: { + Raw: { Data: mail.encodeUtf8() }, + }, + }); + + const res = await this._ses.send(sendCommand); + awsMessageId = res.MessageId; + } catch (cause) { + mail.throwDeliverError( + this, + "failed to call send-email api of aws.", + cause, + ); + } + + if (awsMessageId == null) { + mail.setDelivered(this, new Error("No message id is returned from aws.")); + } + mail.awsMessageId = awsMessageId ?? null; + } +} |