[poolifier.git] / examples / typescript / smtp-client-pool / src / worker.ts

import { createTransport } from 'nodemailer'
import type SMTPTransport from 'nodemailer/lib/smtp-transport/index.js'
import { ThreadWorker } from 'poolifier'

import type { WorkerData } from './types.js'

class SmtpClientWorker extends ThreadWorker<
WorkerData,
SMTPTransport.SentMessageInfo
> {
  public constructor () {
    super({
      nodemailer: async (workerData?: WorkerData) => {
        return await createTransport(workerData?.smtpTransport).sendMail(
          workerData!.mail
        )
      }
    })
  }
}

export const smtpClientWorker = new SmtpClientWorker()
Commit	Line	Data
	1	import { createTransport } from 'nodemailer'
	2	import type SMTPTransport from 'nodemailer/lib/smtp-transport/index.js'
	3	import { ThreadWorker } from 'poolifier'
	4
	5	import type { WorkerData } from './types.js'
	6
	7	class SmtpClientWorker extends ThreadWorker<
	8	WorkerData,
	9	SMTPTransport.SentMessageInfo
	10	> {
	11	public constructor () {
	12	super({
	13	nodemailer: async (workerData?: WorkerData) => {
	14	return await createTransport(workerData?.smtpTransport).sendMail(
	15	workerData!.mail
	16	)
	17	}
	18	})
	19	}
	20	}
	21
	22	export const smtpClientWorker = new SmtpClientWorker()