PeerTube/shared/extra-utils/miscs/email.ts

69 lines
1.7 KiB
TypeScript
Raw Normal View History

2019-04-24 15:10:37 +02:00
import { ChildProcess, fork } from 'child_process'
import { randomInt } from '../../core-utils/miscs/miscs'
import { parallelTests } from '../server/servers'
class MockSmtpServer {
private static instance: MockSmtpServer
private started = false
2019-01-08 15:51:52 +01:00
private emailChildProcess: ChildProcess
private emails: object[]
private constructor () {
2019-01-08 15:51:52 +01:00
this.emailChildProcess = fork(`${__dirname}/email-child-process`, [])
2020-04-01 14:16:19 +02:00
this.emailChildProcess.on('message', (msg: any) => {
if (msg.email) {
return this.emails.push(msg.email)
}
})
2019-01-09 15:14:29 +01:00
process.on('exit', () => this.kill())
}
collectEmails (emailsCollection: object[]) {
2019-04-24 15:10:37 +02:00
return new Promise<number>((res, rej) => {
const port = parallelTests() ? randomInt(1000, 2000) : 1025
if (this.started) {
this.emails = emailsCollection
return res()
}
// ensure maildev isn't started until
// unexpected exit can be reported to test runner
2019-04-24 15:10:37 +02:00
this.emailChildProcess.send({ start: true, port })
this.emailChildProcess.on('exit', () => {
return rej(new Error('maildev exited unexpectedly, confirm port not in use'))
})
2020-04-01 14:16:19 +02:00
this.emailChildProcess.on('message', (msg: any) => {
if (msg.err) {
return rej(new Error(msg.err))
}
this.started = true
this.emails = emailsCollection
2019-04-24 15:10:37 +02:00
return res(port)
})
})
}
2019-01-08 15:51:52 +01:00
kill () {
2019-01-09 15:14:29 +01:00
if (!this.emailChildProcess) return
2019-01-08 15:51:52 +01:00
process.kill(this.emailChildProcess.pid)
this.emailChildProcess = null
MockSmtpServer.instance = null
}
static get Instance () {
return this.instance || (this.instance = new this())
}
2018-01-30 15:16:24 +01:00
}
// ---------------------------------------------------------------------------
export {
MockSmtpServer
2018-01-30 15:16:24 +01:00
}