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 | |
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')
-rw-r--r-- | shared/extra-utils/mock-servers/index.ts | 4 | ||||
-rw-r--r-- | shared/extra-utils/mock-servers/mock-email.ts | 64 | ||||
-rw-r--r-- | shared/extra-utils/mock-servers/mock-joinpeertube-versions.ts (renamed from shared/extra-utils/mock-servers/joinpeertube-versions.ts) | 0 | ||||
-rw-r--r-- | shared/extra-utils/mock-servers/mock-plugin-blocklist.ts | 37 |
4 files changed, 105 insertions, 0 deletions
diff --git a/shared/extra-utils/mock-servers/index.ts b/shared/extra-utils/mock-servers/index.ts new file mode 100644 index 000000000..0ec07f685 --- /dev/null +++ b/shared/extra-utils/mock-servers/index.ts | |||
@@ -0,0 +1,4 @@ | |||
1 | export * from './mock-email' | ||
2 | export * from './mock-instances-index' | ||
3 | export * from './mock-joinpeertube-versions' | ||
4 | export * from './mock-plugin-blocklist' | ||
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 | } | ||
diff --git a/shared/extra-utils/mock-servers/joinpeertube-versions.ts b/shared/extra-utils/mock-servers/mock-joinpeertube-versions.ts index 5ea432ecf..5ea432ecf 100644 --- a/shared/extra-utils/mock-servers/joinpeertube-versions.ts +++ b/shared/extra-utils/mock-servers/mock-joinpeertube-versions.ts | |||
diff --git a/shared/extra-utils/mock-servers/mock-plugin-blocklist.ts b/shared/extra-utils/mock-servers/mock-plugin-blocklist.ts new file mode 100644 index 000000000..d18f8224f --- /dev/null +++ b/shared/extra-utils/mock-servers/mock-plugin-blocklist.ts | |||
@@ -0,0 +1,37 @@ | |||
1 | import * as express from 'express' | ||
2 | import { Server } from 'http' | ||
3 | import { randomInt } from '@shared/core-utils' | ||
4 | |||
5 | type BlocklistResponse = { | ||
6 | data: { | ||
7 | value: string | ||
8 | action?: 'add' | 'remove' | ||
9 | updatedAt?: string | ||
10 | }[] | ||
11 | } | ||
12 | |||
13 | export class MockBlocklist { | ||
14 | private body: BlocklistResponse | ||
15 | private server: Server | ||
16 | |||
17 | initialize () { | ||
18 | return new Promise<number>(res => { | ||
19 | const app = express() | ||
20 | |||
21 | app.get('/blocklist', (req: express.Request, res: express.Response) => { | ||
22 | return res.json(this.body) | ||
23 | }) | ||
24 | |||
25 | const port = 42201 + randomInt(1, 100) | ||
26 | this.server = app.listen(port, () => res(port)) | ||
27 | }) | ||
28 | } | ||
29 | |||
30 | replace (body: BlocklistResponse) { | ||
31 | this.body = body | ||
32 | } | ||
33 | |||
34 | terminate () { | ||
35 | if (this.server) this.server.close() | ||
36 | } | ||
37 | } | ||