services/docker/mail-server/aws-sendmail/delivers/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

import { getLogger } from "../logger.ts";
import { MailDeliverer } from "../deliver.ts";
import { Mail } 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) {
      this.throwError("external error.", mail, cause);
    }

    if (!status.success) {
      this.throwError(`${ldaBin} exited with non-zero.`, mail);
    }
  }
}