diff options
author | Chocobozzz <me@florianbigard.com> | 2021-07-21 15:51:30 +0200 |
---|---|---|
committer | Chocobozzz <me@florianbigard.com> | 2021-07-21 15:51:30 +0200 |
commit | a24bd1ed41b43790bab6ba789580bb4e85f07d85 (patch) | |
tree | a54b0f6c921ba83a6e909cd0ced325b2d4b8863c /shared/extra-utils/mock-servers/mock-email.ts | |
parent | 5f26f13b3c16ac5ae0a3b0a7142d84a9528cf565 (diff) | |
parent | c63830f15403ac4e750829f27d8bbbdc9a59282c (diff) | |
download | PeerTube-a24bd1ed41b43790bab6ba789580bb4e85f07d85.tar.gz PeerTube-a24bd1ed41b43790bab6ba789580bb4e85f07d85.tar.zst PeerTube-a24bd1ed41b43790bab6ba789580bb4e85f07d85.zip |
Merge branch 'next' into develop
Diffstat (limited to 'shared/extra-utils/mock-servers/mock-email.ts')
-rw-r--r-- | shared/extra-utils/mock-servers/mock-email.ts | 64 |
1 files changed, 64 insertions, 0 deletions
diff --git a/shared/extra-utils/mock-servers/mock-email.ts b/shared/extra-utils/mock-servers/mock-email.ts new file mode 100644 index 000000000..ffd62e325 --- /dev/null +++ b/shared/extra-utils/mock-servers/mock-email.ts | |||
@@ -0,0 +1,64 @@ | |||
1 | import { ChildProcess } from 'child_process' | ||
2 | import { randomInt } from '@shared/core-utils' | ||
3 | import { parallelTests } from '../miscs' | ||
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 | } | ||