mail.js

js

const { parentPort, workerData } = require('worker_threads');
const { sendMail } = require("../module/mailer");

// Perform send mail
parentPort.once("message", (message) => {
    message.forEach(async item => {
        await sendMail(item.transporterOptions, item.mailOptions, item.num);
    });
});

// Send the hashedArray to the parent thread
// parentPort.postMessage("Oke sended!");
// process.exit();