1 files changed, 53 insertions, 0 deletions
diff --git a/services/docker/mail-server/relay/aws/deliver.ts b/services/docker/mail-server/relay/aws/deliver.ts
new file mode 100644
index 0000000..793c85a
--- /dev/null
+++ b/services/docker/mail-server/relay/aws/deliver.ts
@@ -0,0 +1,53 @@
+import { SendEmailCommand, SESv2Client } from "@aws-sdk/client-sesv2";
+
+import { AwsContext } from "./context.ts";
+import {
+  Mail,
+  MailDeliverContext,
+  MailDeliverer,
+  MailDeliverReceiptResult,
+} from "./mail.ts";
+import { warn } from "../logger.ts";
+import { log } from "node:console";
+
+export class AwsMailDeliverer extends MailDeliverer {
+  readonly name = "aws";
+  readonly #ses;
+
+  constructor(aws: AwsContext) {
+    super();
+    this.#ses = new SESv2Client(aws);
+  }
+
+  protected override async doDeliver(
+    mail: Mail,
+    context: MailDeliverContext,
+  ): Promise<void> {
+    log("Begin to call aws send-email api...");
+
+    const result: MailDeliverReceiptResult = {
+      kind: "done",
+      message: "Success to call send-email api of aws.",
+    };
+
+    try {
+      const sendCommand = new SendEmailCommand({
+        Content: {
+          Raw: { Data: mail.toUtf8Bytes() },
+        },
+      });
+
+      const res = await this.#ses.send(sendCommand);
+      if (res.MessageId == null) {
+        warn("Aws send-email returns no message id.");
+      }
+      mail.awsMessageId = res.MessageId;
+    } catch (cause) {
+      result.kind = "fail";
+      result.message = "An error was thrown when calling aws send-email." +
+        cause;
+      result.cause = cause;
+    }
+    context.result.set("*", result);
+  }
+}