server/controllers/api/jobs.ts

   1 import * as express from 'express'
   2 import { ResultList } from '../../../shared'
   3 import { Job, JobType, JobState } from '../../../shared/models'
   4 import { UserRight } from '../../../shared/models/users'
   5 import { JobQueue } from '../../lib/job-queue'
   6 import {
   7   asyncMiddleware,
   8   authenticate,
   9   ensureUserHasRight,
  10   jobsSortValidator,
  11   setDefaultPagination,
  12   setDefaultSort
  13 } from '../../middlewares'
  14 import { paginationValidator } from '../../middlewares/validators'
  15 import { listJobsValidator } from '../../middlewares/validators/jobs'
  16
  17 const jobsRouter = express.Router()
  18
  19 jobsRouter.get('/:state',
  20   authenticate,
  21   ensureUserHasRight(UserRight.MANAGE_JOBS),
  22   paginationValidator,
  23   jobsSortValidator,
  24   setDefaultSort,
  25   setDefaultPagination,
  26   asyncMiddleware(listJobsValidator),
  27   asyncMiddleware(listJobs)
  28 )
  29
  30 // ---------------------------------------------------------------------------
  31
  32 export {
  33   jobsRouter
  34 }
  35
  36 // ---------------------------------------------------------------------------
  37
  38 async function listJobs (req: express.Request, res: express.Response, next: express.NextFunction) {
  39   const sort = req.query.sort === 'createdAt' ? 'ASC' : 'DESC'
  40
  41   const jobs = await JobQueue.Instance.listForApi(req.params.state, req.query.start, req.query.count, sort)
  42   const total = await JobQueue.Instance.count(req.params.state)
  43
  44   const result: ResultList<any> = {
  45     total,
  46     data: jobs.map(j => formatJob(j.toJSON()))
  47   }
  48   return res.json(result)
  49 }
  50
  51 function formatJob (job: any): Job {
  52   return {
  53     id: job.id,
  54     state: job.state as JobState,
  55     type: job.type as JobType,
  56     data: job.data,
  57     error: job.error,
  58     createdAt: new Date(parseInt(job.created_at, 10)),
  59     updatedAt: new Date(parseInt(job.updated_at, 10))
  60   }
  61 }