1 files changed, 10 insertions, 25 deletions
diff --git a/services/docker/mail-server/aws-sendmail/delivers/dovecot.ts b/services/docker/mail-server/aws-sendmail/delivers/dovecot.ts
index e30c558..2b35872 100644
--- a/services/docker/mail-server/aws-sendmail/delivers/dovecot.ts
+++ b/services/docker/mail-server/aws-sendmail/delivers/dovecot.ts
@@ -1,31 +1,20 @@
-import { Logger } from "../logger.ts";
-import { MailDeliverContext, MailDeliverer } from "../deliver.ts";
+import { getLogger } from "../logger.ts";
+import { MailDeliverer } from "../deliver.ts";
+import { Mail } from "../mail.ts";
 
 export class DovecotMailDeliverer extends MailDeliverer {
-  constructor(private readonly logger: Logger) {
+  constructor() {
     super("dovecot");
   }
 
   readonly ldaBin = "dovecot-lda";
 
-  protected override doPrepare(
-    rawMail: string,
-  ): Promise<MailDeliverContext> {
-    return Promise.resolve(new MailDeliverContext(rawMail));
-  }
-
-  protected override async doDeliver(
-    context: MailDeliverContext,
-  ): Promise<void> {
-    const { logger, ldaBin } = this;
-    const { rawMail } = context;
+  protected override async doDeliver(mail: Mail): Promise<void> {
+    const { ldaBin } = this;
     let status;
 
     try {
-      const utf8Encoder = new TextEncoder();
-      // TODO: A problem here is if mail is VERY long, this will block for a long time.
-      // Maybe some task queue can be used.
-      const utf8Stream = utf8Encoder.encode(rawMail);
+      const utf8Stream = mail.encodeUtf8();
 
       const ldaCommand = new Deno.Command(ldaBin, {
         stdin: "piped",
@@ -33,7 +22,7 @@ export class DovecotMailDeliverer extends MailDeliverer {
         stderr: "piped",
       });
       const ldaProcess = ldaCommand.spawn();
-      logger.logProgramOutput(ldaProcess, ldaBin);
+      getLogger().logProgramOutput(ldaProcess, ldaBin);
 
       const stdinWriter = ldaProcess.stdin.getWriter();
       await stdinWriter.ready;
@@ -42,15 +31,11 @@ export class DovecotMailDeliverer extends MailDeliverer {
 
       status = await ldaProcess.status;
     } catch (cause) {
-      this.throwError(
-        "external error.",
-        rawMail,
-        cause,
-      );
+      this.throwError("external error.", mail, cause);
     }
 
     if (!status.success) {
-      this.throwError(`${ldaBin} exited with non-zero.`, rawMail);
+      this.throwError(`${ldaBin} exited with non-zero.`, mail);
     }
   }
 }