aboutsummaryrefslogtreecommitdiff
path: root/services/docker/mail-server/aws-sendmail/dovecot.ts
diff options
context:
space:
mode:
Diffstat (limited to 'services/docker/mail-server/aws-sendmail/dovecot.ts')
-rw-r--r--services/docker/mail-server/aws-sendmail/dovecot.ts40
1 files changed, 40 insertions, 0 deletions
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..9097cd0
--- /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.toUtf8Bytes();
+
+ 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.`);
+ }
+ }
+}