]>
Commit | Line | Data |
---|---|---|
1 | import { ChildProcess } from 'child_process' | |
2 | import { randomInt } from '../../core-utils/miscs/miscs' | |
3 | import { parallelTests } from '../server/servers' | |
4 | ||
5 | const MailDev = require('maildev') | |
6 | ||
7 | class MockSmtpServer { | |
8 | ||
9 | private static instance: MockSmtpServer | |
10 | private started = false | |
11 | private emailChildProcess: ChildProcess | |
12 | private emails: object[] | |
13 | ||
14 | private constructor () { } | |
15 | ||
16 | collectEmails (emailsCollection: object[]) { | |
17 | return new Promise<number>((res, rej) => { | |
18 | const port = parallelTests() ? randomInt(1000, 2000) : 1025 | |
19 | this.emails = emailsCollection | |
20 | ||
21 | if (this.started) { | |
22 | return res(undefined) | |
23 | } | |
24 | ||
25 | const maildev = new MailDev({ | |
26 | ip: '127.0.0.1', | |
27 | smtp: port, | |
28 | disableWeb: true, | |
29 | silent: true | |
30 | }) | |
31 | ||
32 | maildev.on('new', email => { | |
33 | this.emails.push(email) | |
34 | }) | |
35 | ||
36 | maildev.listen(err => { | |
37 | if (err) return rej(err) | |
38 | ||
39 | this.started = true | |
40 | ||
41 | return res(port) | |
42 | }) | |
43 | }) | |
44 | } | |
45 | ||
46 | kill () { | |
47 | if (!this.emailChildProcess) return | |
48 | ||
49 | process.kill(this.emailChildProcess.pid) | |
50 | ||
51 | this.emailChildProcess = null | |
52 | MockSmtpServer.instance = null | |
53 | } | |
54 | ||
55 | static get Instance () { | |
56 | return this.instance || (this.instance = new this()) | |
57 | } | |
58 | } | |
59 | ||
60 | // --------------------------------------------------------------------------- | |
61 | ||
62 | export { | |
63 | MockSmtpServer | |
64 | } |