diff options
Diffstat (limited to 'shared/extra-utils/mock-servers')
-rw-r--r-- | shared/extra-utils/mock-servers/index.ts | 1 | ||||
-rw-r--r-- | shared/extra-utils/mock-servers/mock-email.ts | 64 |
2 files changed, 65 insertions, 0 deletions
diff --git a/shared/extra-utils/mock-servers/index.ts b/shared/extra-utils/mock-servers/index.ts index 47679c818..485757843 100644 --- a/shared/extra-utils/mock-servers/index.ts +++ b/shared/extra-utils/mock-servers/index.ts | |||
@@ -1,2 +1,3 @@ | |||
1 | export * from './mock-email' | ||
1 | export * from './mock-instances-index' | 2 | export * from './mock-instances-index' |
2 | export * from './mock-joinpeertube-versions' | 3 | export * from './mock-joinpeertube-versions' |
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..9fc9a5ad0 --- /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 '../../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 | } | ||