mirror of
https://github.com/TryGhost/Ghost.git
synced 2025-01-03 08:25:06 +03:00
5b6fe31002
no issue - These changes should allow easy testing of scheduled jobs and provide an implementation example for future jobs within Ghost - Added experimental support to run jobs based on functions defined in modules - Extendeded testmode "schedule" endpoint with an optional job name parameter which picks up job from "jobs" folder - Adjusted scheduleJob method use and passed "schedule" as first parameter - Bumped job-manager version to allow for all new functionality
73 lines
2.4 KiB
JavaScript
73 lines
2.4 KiB
JavaScript
const path = require('path');
|
|
const logging = require('../../../../shared/logging');
|
|
const express = require('../../../../shared/express');
|
|
const jobService = require('../../../services/jobs');
|
|
|
|
/** A bunch of helper routes for testing purposes */
|
|
module.exports = function testRoutes() {
|
|
const router = express.Router('canary admin');
|
|
|
|
router.get('/500', (req, res) => res.sendStatus(500));
|
|
router.get('/400', (req, res) => res.sendStatus(400));
|
|
router.get('/404', (req, res) => res.sendStatus(404));
|
|
router.get('/slow/:timeout', (req, res) => {
|
|
if (!req.params || !req.params.timeout) {
|
|
return res.sendStatus(200);
|
|
}
|
|
const timeout = req.params.timeout * 1000;
|
|
logging.info('Begin Slow Request with timeout of', timeout);
|
|
setTimeout(() => {
|
|
logging.info('End Slow Request', timeout);
|
|
res.sendStatus(200);
|
|
}, timeout);
|
|
});
|
|
router.get('/job/:timeout', (req, res) => {
|
|
if (!req.params || !req.params.timeout) {
|
|
return res.sendStatus(200);
|
|
}
|
|
|
|
const timeout = req.params.timeout * 1000;
|
|
logging.info('Create Slow Job with timeout of', timeout);
|
|
jobService.addJob(() => {
|
|
return new Promise((resolve) => {
|
|
logging.info('Start Slow Job');
|
|
setTimeout(() => {
|
|
logging.info('End Slow Job', timeout);
|
|
resolve();
|
|
}, timeout);
|
|
});
|
|
});
|
|
|
|
res.sendStatus(202);
|
|
});
|
|
|
|
router.get('/schedule/:schedule/:name*?', (req, res) => {
|
|
if (!req.params.schedule) {
|
|
return res.sendStatus(400, 'schedule parameter cannot be mepty');
|
|
}
|
|
|
|
const schedule = req.params.schedule;
|
|
logging.info('Achedule a Job with schedule of:', schedule, req.params.name);
|
|
|
|
if (req.params.name) {
|
|
const jobPath = path.resolve(__dirname, 'jobs', req.params.name);
|
|
jobService.scheduleJob(schedule, jobPath);
|
|
} else {
|
|
jobService.scheduleJob(schedule, () => {
|
|
return new Promise((resolve) => {
|
|
logging.info('Start scheduled Job');
|
|
|
|
setTimeout(() => {
|
|
logging.info('End scheduled Job run', schedule);
|
|
resolve();
|
|
}, 20 * 1000);
|
|
});
|
|
}, {});
|
|
}
|
|
|
|
res.sendStatus(202);
|
|
});
|
|
|
|
return router;
|
|
};
|