DEV Community: SH-Hong

How to Send Email Using Cron Job in Node.js

SH-Hong — Wed, 22 May 2024 14:05:21 +0000

Automating email sending is a common requirement in many applications, whether for sending newsletters, reminders, or notifications. Using cron jobs in Node.js can simplify this task significantly. In this post, we'll walk through setting up an email automation system using the Pulse library, which leverages MongoDB for task management.

Setting Up Your Environment

First, ensure you have Node.js and MongoDB installed on your system. Then, create a new Node.js project and install the necessary packages:

npm init -y
npm install express @pulsecron/pulse nodemailer --save

Integrate Pulse with Express

Here’s a step-by-step guide to integrating Pulse with an Express application for email scheduling:

1.Import Dependencies and Setup Express

Begin by importing required modules and setting up the Express server:

import express from 'express';
import Pulse from 'pulse';
import nodemailer from 'nodemailer';

const app = express();
const port = 3000;
app.use(express.json());

2.Configure Pulse

Set up Pulse to connect to MongoDB, where jobs will be managed:

const mongoConnectionString = 'mongodb://localhost:27017/pulse';
const pulse = new Pulse({
  db: { address: mongoConnectionString, collection: 'cronjob' },
  defaultConcurrency: 4,
  maxConcurrency: 4,
  processEvery: '10 seconds',
  resumeOnRestart: true
});

3.Configure Nodemailer

Set up Nodemailer for sending emails:

const transporter = nodemailer.createTransport({
  service: 'gmail',
  auth: {
    user: 'your-email@gmail.com',
    pass: 'your-email-password'
  }
});

4.Define Email Job

Create a job definition for sending emails:

pulse.define('send email', async (job, done) => {
  const { to, subject, text } = job.attrs.data;
  const mailOptions = {
    from: 'your-email@gmail.com',
    to,
    subject,
    text
  };

  try {
    await transporter.sendMail(mailOptions);
    console.log(`Email sent to ${to}`);
    done();
  } catch (error) {
    console.error(`Failed to send email to ${to}`, error);
    done(error);
  }
}, { shouldSaveResult: true });

5.Express Route to Trigger Email Job

Implement a route to schedule emails:

app.post('/send-email', async (req, res) => {
  try {
    await pulse.start();
    const { to, subject, text, scheduleTime } = req.body;
    const job = pulse.create('send email', { to, subject, text });
    await job.schedule(new Date(scheduleTime)).save();
    res.status(200).send('Email scheduled successfully');
  } catch (error) {
    console.error(error);
    res.status(500).send('Failed to schedule email');
  }
});

6.Event Listeners

Add listeners for various job events:

pulse.on('success', (job) => {
  console.log(`Job <${job.attrs.name}> succeeded`);
});

pulse.on('fail', (error, job) => {
  console.log(`Job <${job.attrs.name}> failed:`, error);
});

7.Start the Server

Launch your Express server:

app.listen(port, () => {
  console.log(`Server running on http://localhost:${port}`);
});

Conclusion

Implementing and managing such a system yourself is necessary but can be tedious and time-consuming. To focus more on product engineering, consider using a cloud service like Pulsecron for your scheduling needs. Pulsecron offers a managed solution that simplifies the entire process, allowing you to concentrate on building great features for your users.

👉 For the complete code and further details, please refer to the GitHub repository

👉 Learn more about Pulsecron's event-based scheduling solutions

👉 Join our open source project related to this topic

Getting Started Task Scheduling and Cron Jobs in Node.js with MongoDB

SH-Hong — Sat, 18 May 2024 07:34:17 +0000

Scheduling tasks in a Node.js application can be crucial for automating emails, generating reports, and more. In this post, we'll explore how to set up a robust scheduling system using the Pulse library, integrated with an Express server. This approach uses MongoDB to manage tasks, ensuring durability and resilience.

Setting Up Your Environment

First, ensure you have Node.js and MongoDB installed on your system. Then, create a new Node.js project and install the necessary packages:

npm init -y
npm install express mongodb pulse --save

Integrate Pulse with Express

Here’s a step-by-step guide to integrating Pulse with an Express application for task scheduling:

1. Import Dependencies and Setup Express

Begin by importing required modules and setting up the Express server:

import express from 'express';
const app = express();
const port = 3000;

2. Configure Pulse

Set up Pulse to connect to MongoDB, where jobs will be managed:

const mongoConnectionString = 'mongodb://localhost:27017/pulse';
const pulse = new Pulse({
  db: { address: mongoConnectionString, collection: 'cronjob' },
  defaultConcurrency: 4,
  maxConcurrency: 4,
  processEvery: '10 seconds',
  resumeOnRestart: true
});

3. Define Jobs

Create job definitions. For instance, a job to send emails and another to generate reports:

pulse.define('send nudge email', async (job, done) => {
  const { to } = job.attrs.data;
  // Add email sending logic here
  done();
}, { shouldSaveResult: true,  attempts: 5, backoff: { type: 'exponential', delay: 1000 }});

pulse.define('send weekly report', async (job, done) => {
  const { to } = job.attrs.data;
  // Add report generation logic here
  done();
}, { shouldSaveResult: true, attempts: 5, backoff: { type: 'exponential', delay: 1000 }});

4. Express Routes to Trigger Jobs

Implement routes to schedule emails and reports:

app.post('/send-nudge-email', async (req, res) => {
  await pulse.start();
  const job = pulse.create('send nudge email', { to: req.body.to });
  await job.schedule(new Date(Date.now() + 259200000)).save(); // 3 days later
  res.status(200).send('Nudge email scheduled successfully');
});

app.post('/send-weekly-report', async (req, res) => {
  await pulse.start();
  const job = pulse.create('send weekly report', { to: req.body.to });
  await job.repeatEvery('1 week').save();
  res.status(200).send('Weekly report scheduled successfully');
});

5. Event Listeners

Add listeners for various job events:

pulse.on('success', (job) => {
  console.log(time(), `Job <${job.attrs.name}> succeeded`);
});

6. Start the Server

Launch your Express server:

app.listen(port, () => {
  console.log(`Server running on http://localhost:${port}`);
});

Conclusion

👉 For the complete code and further details, please refer to the GitHub repository

👉 Learn more about Pulsecron's event-based scheduling solutions

👉 Join our open source project related to this topic

How to activate open source communities

SH-Hong — Thu, 16 May 2024 13:55:50 +0000

Please give me a little advice.

Currently I'm creating an open source library for node.js. But I don't get as much attention from users as I want. What should I do? Should I just wait unconditionally?

How can I promote an open-source project?