Ghost/core/server/web/api/testmode/routes.js
Sam Lord caea330647 Change to use @tryghost/logging
no issue

Logging is now controlled by a logginrc.js file in the root of the project - and now we can just import @tryghost/logging everywhere
2021-06-15 15:59:11 +01:00

82 lines
2.7 KiB
JavaScript

const path = require('path');
const logging = require('@tryghost/logging');
const express = require('../../../../shared/express');
const jobsService = 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);
jobsService.addJob({
job: () => {
return new Promise((resolve) => {
logging.info('Start Slow Job');
setTimeout(() => {
logging.info('End Slow Job', timeout);
resolve();
}, timeout);
});
},
offloaded: false
});
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;
const jobName = req.params.name || `generic-${new Date().getTime()}`;
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}.js`);
jobsService.addJob({
at: schedule,
job: jobPath,
name: jobName
});
} else {
jobsService.addJob({
at: schedule,
job: () => {
return new Promise((resolve) => {
setTimeout(() => {
resolve();
}, 20 * 1000);
});
},
name: jobName
});
}
res.sendStatus(202);
});
return router;
};