aboutsummaryrefslogblamecommitdiffhomepage
path: root/shared/extra-utils/miscs/email.ts
blob: 758b15b58aff88bd81e6751b2766e9e3c33409b4 (plain) (tree)
1
2
3
4
5
6
7
8
9
                                                  
                           

                                                        




                                         
                                         


                          
                                                                             
 
                                                        



                                          

                                         


                                              


                                                                 

                                      
                             



                                                       
                                                        


                                                                                     
                                                          

                                                   

                                      
 
                        



        
           

                                       





                                            


                                                        




                                                                              
                
 
import { ChildProcess, fork } from 'child_process'
import { join } from 'path'
import { randomInt } from '../../core-utils/miscs/miscs'
import { parallelTests } from '../server/servers'

class MockSmtpServer {

  private static instance: MockSmtpServer
  private started = false
  private emailChildProcess: ChildProcess
  private emails: object[]

  private constructor () {
    this.emailChildProcess = fork(join(__dirname, 'email-child-process'), [])

    this.emailChildProcess.on('message', (msg: any) => {
      if (msg.email) {
        return this.emails.push(msg.email)
      }
    })

    process.on('exit', () => this.kill())
  }

  collectEmails (emailsCollection: object[]) {
    return new Promise<number>((res, rej) => {
      const port = parallelTests() ? randomInt(1000, 2000) : 1025

      if (this.started) {
        this.emails = emailsCollection
        return res(undefined)
      }

      // ensure maildev isn't started until
      // unexpected exit can be reported to test runner
      this.emailChildProcess.send({ start: true, port })
      this.emailChildProcess.on('exit', () => {
        return rej(new Error('maildev exited unexpectedly, confirm port not in use'))
      })
      this.emailChildProcess.on('message', (msg: any) => {
        if (msg.err) return rej(new Error(msg.err))

        this.started = true
        this.emails = emailsCollection

        return res(port)
      })
    })
  }

  kill () {
    if (!this.emailChildProcess) return

    process.kill(this.emailChildProcess.pid)

    this.emailChildProcess = null
    MockSmtpServer.instance = null
  }

  static get Instance () {
    return this.instance || (this.instance = new this())
  }
}

// ---------------------------------------------------------------------------

export {
  MockSmtpServer
}