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