blob: 9097cd0e644db1e0aadd83bf14eeb66a31136351 (
plain)
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
|
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.`);
}
}
}
|