Я создал генератор случайных чисел, который каждый день отправляет электронное письмо с цитатой. Чтобы построить это, я использовал пакет node-schedule.
Я указал, что каждый день в 16:00 он должен выполнять функцию:
schedule.scheduleJob("* * 16 * * *", () => {
scheduler();
console.log("hey");
});
Но оказывается, что он это делаетмного раз, а не только один раз.
В чем проблема?
Вот полный код:
const express = require("express");
const app = express();
const nodemailer = require("nodemailer");
const fetch = require("node-fetch");
const schedule = require("node-schedule");
app.get("*", (req, res) => {
res.send("<h1>Hello, wolrd!</h1>");
});
schedule.scheduleJob("* * 16 * * *", () => {
scheduler();
console.log("hey");
});
function scheduler() {
let qoute = {};
fetch("https://api.quotable.io/random", {
method: "GET"
})
.then(data => {
return data.json();
})
.then(info => {
qoute.qoute = info.content;
qoute.author = info.author;
mailer(qoute);
})
.catch(error => console.error(error));
}
// async..await is not allowed in global scope, must use a wrapper
async function mailer(qoute) {
// Generate test SMTP service account from ethereal.email
// Only needed if you don't have a real mail account for testing
// let testAccount = await nodemailer.createTestAccount();
// create reusable transporter object using the default SMTP transport
let transporter = nodemailer.createTransport({
host: "mail.google.com",
port:123,
secure: false, // true for 465, false for other ports
auth: {
user: "robot@gmail.com", // generated ethereal user
pass: "123456" // generated ethereal password
}
});
// send mail with defined transport object
let info = await transporter.sendMail(
{
from: '"John doe ?" <hello@mail.com>', // sender address
to: "abc@gmail.com", // list of receivers
subject: `? Here's your daily qoute`, // Subject line
html: `
<b>${qoute.qoute} <span>-${qoute.author}</span>
`
},
function(err, info) {
if (err) console.log(err);
else console.log(info);
}
);
}
const port = process.env.PORT || 5000;
app.listen(port, () => console.log(`listening on port: ${port}`));
Итак, для результата я ожидаю, что это scheduler()
Функция должна запускаться только один раз.
Спасибо.