3 files changed, 95 insertions, 0 deletions
diff --git a/services/docker/mail-server/aws-sendmail/delivers/aws.ts b/services/docker/mail-server/aws-sendmail/delivers/aws.ts
new file mode 100644
index 0000000..85d86ec
--- /dev/null
+++ b/services/docker/mail-server/aws-sendmail/delivers/aws.ts
@@ -0,0 +1,28 @@
+import { SESv2Client } from "@aws-sdk/client-sesv2";
+
+import { AwsContext } from "../aws.ts";
+import { MailDeliverer, MailDeliverContext } from "../deliver.ts";
+
+export class AwsMailDeliverContext extends MailDeliverContext {
+  awsMessageId: string | null = null;
+
+  constructor(rawMail: string) {
+    super(rawMail);
+  }
+}
+
+class AwsMailDeliverer extends MailDeliverer<AwsMailDeliverContext> {
+  private _ses;
+
+  constructor(readonly aws: AwsContext) {
+    super("aws");
+    this._ses = new SESv2Client({ credentials: aws.awsCredentialsProvider });
+  }
+
+  protected override doPrepare(rawMail: string): Promise<AwsMailDeliverContext> {
+    return Promise.resolve(new AwsMailDeliverContext(rawMail))
+  }
+
+  protected override async doDeliver(context: AwsContext): Promise<void> {
+  }
+}
diff --git a/services/docker/mail-server/aws-sendmail/delivers/dovecot.ts b/services/docker/mail-server/aws-sendmail/delivers/dovecot.ts
new file mode 100644
index 0000000..e30c558
--- /dev/null
+++ b/services/docker/mail-server/aws-sendmail/delivers/dovecot.ts
@@ -0,0 +1,56 @@
+import { Logger } from "../logger.ts";
+import { MailDeliverContext, MailDeliverer } from "../deliver.ts";
+
+export class DovecotMailDeliverer extends MailDeliverer {
+  constructor(private readonly logger: Logger) {
+    super("dovecot");
+  }
+
+  readonly ldaBin = "dovecot-lda";
+
+  protected override doPrepare(
+    rawMail: string,
+  ): Promise<MailDeliverContext> {
+    return Promise.resolve(new MailDeliverContext(rawMail));
+  }
+
+  protected override async doDeliver(
+    context: MailDeliverContext,
+  ): Promise<void> {
+    const { logger, ldaBin } = this;
+    const { rawMail } = context;
+    let status;
+
+    try {
+      const utf8Encoder = new TextEncoder();
+      // TODO: A problem here is if mail is VERY long, this will block for a long time.
+      // Maybe some task queue can be used.
+      const utf8Stream = utf8Encoder.encode(rawMail);
+
+      const ldaCommand = new Deno.Command(ldaBin, {
+        stdin: "piped",
+        stdout: "piped",
+        stderr: "piped",
+      });
+      const ldaProcess = ldaCommand.spawn();
+      logger.logProgramOutput(ldaProcess, ldaBin);
+
+      const stdinWriter = ldaProcess.stdin.getWriter();
+      await stdinWriter.ready;
+      await stdinWriter.write(utf8Stream);
+      await stdinWriter.ready;
+
+      status = await ldaProcess.status;
+    } catch (cause) {
+      this.throwError(
+        "external error.",
+        rawMail,
+        cause,
+      );
+    }
+
+    if (!status.success) {
+      this.throwError(`${ldaBin} exited with non-zero.`, rawMail);
+    }
+  }
+}
diff --git a/services/docker/mail-server/aws-sendmail/delivers/traffic.ts b/services/docker/mail-server/aws-sendmail/delivers/traffic.ts
new file mode 100644
index 0000000..a3ff52b
--- /dev/null
+++ b/services/docker/mail-server/aws-sendmail/delivers/traffic.ts
@@ -0,0 +1,11 @@
+import { Logger } from "../logger.ts";
+import { MailDeliverer } from "../deliver.ts";
+import { DovecotMailDeliverer } from "./dovecot.ts";
+
+export class MailTrafficDeliverer {
+  receiver: MailDeliverer;
+
+  constructor(logger: Logger) {
+    this.receiver = new DovecotMailDeliverer(logger);
+  }
+}