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

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