services/docker/mail-server/relay/dovecot.ts


1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42

import { getLogger } from "./logger.ts";
import { Mail, MailDeliverer } from "./mail.ts";

// https://github.com/dovecot/core/blob/main/src/lib-smtp/smtp-submit.c

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.`);
    }
  }
}