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

import { ThreadWorker } from 'poolifier'
import { createTransport } from 'nodemailer'
import type Mail from 'nodemailer/lib/mailer/index.js'
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 as Mail.Options
        )
      }
    })
  }
}

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