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