shared/server-commands/server/jobs-command.ts

   1 import { pick } from '@shared/core-utils'
   2 import { HttpStatusCode, Job, JobState, JobType, ResultList } from '@shared/models'
   3 import { AbstractCommand, OverrideCommandOptions } from '../shared'
   4
   5 export class JobsCommand extends AbstractCommand {
   6
   7   async getLatest (options: OverrideCommandOptions & {
   8     jobType: JobType
   9   }) {
  10     const { data } = await this.list({ ...options, start: 0, count: 1, sort: '-createdAt' })
  11
  12     if (data.length === 0) return undefined
  13
  14     return data[0]
  15   }
  16
  17   pauseJobQueue (options: OverrideCommandOptions = {}) {
  18     const path = '/api/v1/jobs/pause'
  19
  20     return this.postBodyRequest({
  21       ...options,
  22
  23       path,
  24       implicitToken: true,
  25       defaultExpectedStatus: HttpStatusCode.NO_CONTENT_204
  26     })
  27   }
  28
  29   resumeJobQueue (options: OverrideCommandOptions = {}) {
  30     const path = '/api/v1/jobs/resume'
  31
  32     return this.postBodyRequest({
  33       ...options,
  34
  35       path,
  36       implicitToken: true,
  37       defaultExpectedStatus: HttpStatusCode.NO_CONTENT_204
  38     })
  39   }
  40
  41   list (options: OverrideCommandOptions & {
  42     state?: JobState
  43     jobType?: JobType
  44     start?: number
  45     count?: number
  46     sort?: string
  47   } = {}) {
  48     const path = this.buildJobsUrl(options.state)
  49
  50     const query = pick(options, [ 'start', 'count', 'sort', 'jobType' ])
  51
  52     return this.getRequestBody<ResultList<Job>>({
  53       ...options,
  54
  55       path,
  56       query,
  57       implicitToken: true,
  58       defaultExpectedStatus: HttpStatusCode.OK_200
  59     })
  60   }
  61
  62   listFailed (options: OverrideCommandOptions & {
  63     jobType?: JobType
  64   }) {
  65     const path = this.buildJobsUrl('failed')
  66
  67     return this.getRequestBody<ResultList<Job>>({
  68       ...options,
  69
  70       path,
  71       query: { start: 0, count: 50 },
  72       implicitToken: true,
  73       defaultExpectedStatus: HttpStatusCode.OK_200
  74     })
  75   }
  76
  77   private buildJobsUrl (state?: JobState) {
  78     let path = '/api/v1/jobs'
  79
  80     if (state) path += '/' + state
  81
  82     return path
  83   }
  84 }