From 690f9f843324c359a46bcb8b51b5563e2bec800a Mon Sep 17 00:00:00 2001
From: Yuqian Yang <crupest@crupest.life>
Date: Wed, 30 Apr 2025 00:20:23 +0800
Subject: HALF WORK!: 2025-5-4

---
 .../docker/mail-server/aws-sendmail/dovecot.ts     | 40 ++++++++++++++++++++++
 1 file changed, 40 insertions(+)
 create mode 100644 services/docker/mail-server/aws-sendmail/dovecot.ts

(limited to 'services/docker/mail-server/aws-sendmail/dovecot.ts')

diff --git a/services/docker/mail-server/aws-sendmail/dovecot.ts b/services/docker/mail-server/aws-sendmail/dovecot.ts
new file mode 100644
index 0000000..520f93b
--- /dev/null
+++ b/services/docker/mail-server/aws-sendmail/dovecot.ts
@@ -0,0 +1,40 @@
+import { getLogger } from "./logger.ts";
+import { Mail, MailDeliverer } from "./mail.ts";
+
+export class DovecotMailDeliverer extends MailDeliverer {
+  constructor() {
+    super("dovecot");
+  }
+
+  readonly ldaBin = "dovecot-lda";
+
+  protected override async doDeliver(mail: Mail): Promise<void> {
+    const { ldaBin } = this;
+    let status;
+
+    try {
+      const utf8Stream = mail.encodeUtf8();
+
+      const ldaCommand = new Deno.Command(ldaBin, {
+        stdin: "piped",
+        stdout: "piped",
+        stderr: "piped",
+      });
+      const ldaProcess = ldaCommand.spawn();
+      getLogger().logProgramOutput(ldaProcess, ldaBin);
+
+      const stdinWriter = ldaProcess.stdin.getWriter();
+      await stdinWriter.ready;
+      await stdinWriter.write(utf8Stream);
+      await stdinWriter.ready;
+
+      status = await ldaProcess.status;
+    } catch (cause) {
+      mail.throwDeliverError(this, "external error.", cause);
+    }
+
+    if (!status.success) {
+      mail.throwDeliverError(this, `${ldaBin} exited with non-zero.`);
+    }
+  }
+}
-- 
cgit v1.2.3