moleculer-cron

Cron mixin for Moleculer using cron.

Description

Easy to use cron with Moleculer!

Install

1$ npm install moleculer-cron --save

Usage

Create cron service

Specify all of your cron tasks inside the settings.cronJobs array of the service.

1const CronMixin = require("moleculer-cron");
2
3broker.createService({
4    name: "cron-job",
5
6    mixins: [CronMixin],
7
8    settings: {
9        cronJobs: [
10            {
11                name: "jobHelloWorld",
12                cronTime: '*/5 * * * * *', // Run every 5 seconds
13                manualStart: true, // This job needs to be started manually
14                onTick: async function() {
15                    this.logger.info('JobHelloWorld ticked');
16                    try {
17                        const data = await this.broker.call("cron-job.say");
18                        this.logger.info("Oh!", data);
19                        
20                        // Stop this job and start the other one
21                        this.stopJob("jobHelloWorld");
22                        this.startJob("jobToggle");
23                        this.logger.info("Stopped JobHelloWorld and started JobToggle");
24                    } catch (e) {
25                        this.logger.info("error ", e);
26                    }
27                },
28                onInitialize: function() {
29                    this.logger.info("JobHelloWorld is init");
30                    // This job is manual start, so it won't start automatically
31                },
32                onComplete: function() {
33                    this.logger.info("JobHelloWorld is stopped");
34                }
35            },
36            {
37                name: "jobToggle",
38                cronTime: '*/5 * * * * *', // Run every 5 seconds
39                onTick: function() {
40                    this.logger.info('JobToggle ticked');
41                    
42                    // Stop this job and start the other one
43                    this.stopJob("jobToggle");
44                    this.startJob("jobHelloWorld");
45                    this.logger.info("Stopped JobToggle and started JobHelloWorld");
46                },
47                onInitialize: function() {
48                    this.logger.info("JobToggle is init");
49                    // This job will start automatically
50                },
51                onComplete: function() {
52                    this.logger.info("JobToggle is stopped");
53                }
54            }
55        ]
56    },
57
58    actions: {
59        say: {
60            handler() {
61                return "HelloWorld!";
62            }
63        },
64    }
65});

Available Cron patterns:

• Asterisk. E.g. *
• Ranges. E.g. 1-3,5
• Steps. E.g. */2

Read up on cron patterns here. Note that this library uses six fields, with 1 second as the finest granularity.

Cron Ranges

• Seconds: 0-59
• Minutes: 0-59
• Hours: 0-23
• Day of Month: 1-31
• Months: 0-11 (Jan-Dec)
• Day of Week: 0-6 (Sun-Sat)

API

Job Configuration

• name - [REQUIRED] - Set a name for the job.
• cronTime - [REQUIRED] - The time to fire off your job. This can be in the form of cron syntax or a JS Date object.
• manualStart - [OPTIONAL] - Specifies whether to start the job just before exiting the constructor. Default is false.
• timeZone - [OPTIONAL] - Specify the timezone for the execution. Check all timezones available at Moment Timezone Website.
• onInitialize - [OPTIONAL] - Executed before the cron job is created.
• onStart - [OPTIONAL] - When the cron is starting.
• onStop - [OPTIONAL] - When the cron is stopping.
• onComplete - [OPTIONAL] - A function that will fire when the job is stopped.
• onTick - [REQUIRED] - The function to fire at the specified time.

Mixin Methods

• startJob(jobName) - Starts the specified job.
• stopJob(jobName) - Stops the specified job.
• getJob(jobName) - Returns the job object for the specified job name.

Job Object Methods

• startJob() - Starts the job.
• stopJob() - Stops the job.
• lastDate() - Returns the last execution date of the job.
• running() - Returns whether the job is currently running.
• setTime(time) - Changes the time for the job. time can be a cron string or a Date object.
• nextDates(count) - Returns an array of the next count dates that the job will run.
• addCallback(callback) - Adds an additional callback function to be executed when the job ticks.

Utility Methods

• getCronTime(time) - Returns a CronTime instance for the given time.

Notes

For any issues or feature requests, please create an issue on the GitHub repository. Make sure to search existing issues before creating a new one.