2019-04-24 15:10:37 +02:00
|
|
|
import { ChildProcess, fork } from 'child_process'
|
2021-02-03 09:33:05 +01:00
|
|
|
import { join } from 'path'
|
2019-04-24 15:10:37 +02:00
|
|
|
import { randomInt } from '../../core-utils/miscs/miscs'
|
|
|
|
import { parallelTests } from '../server/servers'
|
2018-12-15 14:51:51 +01:00
|
|
|
|
|
|
|
class MockSmtpServer {
|
|
|
|
|
|
|
|
private static instance: MockSmtpServer
|
|
|
|
private started = false
|
2019-01-08 15:51:52 +01:00
|
|
|
private emailChildProcess: ChildProcess
|
2018-12-15 14:51:51 +01:00
|
|
|
private emails: object[]
|
|
|
|
|
|
|
|
private constructor () {
|
2021-02-03 09:33:05 +01:00
|
|
|
this.emailChildProcess = fork(join(__dirname, 'email-child-process'), [])
|
2019-01-08 15:51:52 +01:00
|
|
|
|
2020-04-01 14:16:19 +02:00
|
|
|
this.emailChildProcess.on('message', (msg: any) => {
|
2018-12-15 14:51:51 +01:00
|
|
|
if (msg.email) {
|
|
|
|
return this.emails.push(msg.email)
|
|
|
|
}
|
|
|
|
})
|
2019-01-09 15:14:29 +01:00
|
|
|
|
|
|
|
process.on('exit', () => this.kill())
|
2018-12-15 14:51:51 +01:00
|
|
|
}
|
|
|
|
|
|
|
|
collectEmails (emailsCollection: object[]) {
|
2019-04-24 15:10:37 +02:00
|
|
|
return new Promise<number>((res, rej) => {
|
|
|
|
const port = parallelTests() ? randomInt(1000, 2000) : 1025
|
|
|
|
|
2018-12-15 14:51:51 +01:00
|
|
|
if (this.started) {
|
|
|
|
this.emails = emailsCollection
|
2021-02-03 09:33:05 +01:00
|
|
|
return res(undefined)
|
2018-12-15 14:51:51 +01:00
|
|
|
}
|
|
|
|
|
|
|
|
// 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 })
|
2018-12-15 14:51:51 +01:00
|
|
|
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) => {
|
2020-06-17 10:55:40 +02:00
|
|
|
if (msg.err) return rej(new Error(msg.err))
|
|
|
|
|
2018-12-15 14:51:51 +01:00
|
|
|
this.started = true
|
|
|
|
this.emails = emailsCollection
|
2020-06-17 10:55:40 +02:00
|
|
|
|
2019-04-24 15:10:37 +02:00
|
|
|
return res(port)
|
2018-12-15 14:51:51 +01:00
|
|
|
})
|
|
|
|
})
|
|
|
|
}
|
|
|
|
|
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
|
|
|
|
}
|
|
|
|
|
2018-12-15 14:51:51 +01:00
|
|
|
static get Instance () {
|
|
|
|
return this.instance || (this.instance = new this())
|
|
|
|
}
|
2018-01-30 15:16:24 +01:00
|
|
|
}
|
|
|
|
|
|
|
|
// ---------------------------------------------------------------------------
|
|
|
|
|
|
|
|
export {
|
2018-12-15 14:51:51 +01:00
|
|
|
MockSmtpServer
|
2018-01-30 15:16:24 +01:00
|
|
|
}
|