From 94a5ff8a4a75d75bb9df542a39ce8769e7a7e6a4 Mon Sep 17 00:00:00 2001 From: Chocobozzz Date: Thu, 25 Jan 2018 15:05:18 +0100 Subject: Move job queue to redis We'll use it as cache in the future. /!\ You'll loose your old jobs (pending jobs too) so upgrade only when you don't have pending job anymore. --- server/models/job/job.ts | 80 ------------------------------------------------ 1 file changed, 80 deletions(-) delete mode 100644 server/models/job/job.ts (limited to 'server/models/job/job.ts') diff --git a/server/models/job/job.ts b/server/models/job/job.ts deleted file mode 100644 index ba1c6737e..000000000 --- a/server/models/job/job.ts +++ /dev/null @@ -1,80 +0,0 @@ -import { values } from 'lodash' -import { AllowNull, Column, CreatedAt, DataType, Model, Table, UpdatedAt } from 'sequelize-typescript' -import { JobCategory, JobState } from '../../../shared/models' -import { JOB_CATEGORIES, JOB_STATES } from '../../initializers' -import { getSort } from '../utils' - -@Table({ - tableName: 'job', - indexes: [ - { - fields: [ 'state', 'category' ] - } - ] -}) -export class JobModel extends Model { - @AllowNull(false) - @Column(DataType.ENUM(values(JOB_STATES))) - state: JobState - - @AllowNull(false) - @Column(DataType.ENUM(values(JOB_CATEGORIES))) - category: JobCategory - - @AllowNull(false) - @Column - handlerName: string - - @AllowNull(true) - @Column(DataType.JSON) - handlerInputData: any - - @CreatedAt - createdAt: Date - - @UpdatedAt - updatedAt: Date - - static listWithLimitByCategory (limit: number, state: JobState, jobCategory: JobCategory) { - const query = { - order: [ - [ 'id', 'ASC' ] - ], - limit: limit, - where: { - state, - category: jobCategory - }, - logging: false - } - - return JobModel.findAll(query) - } - - static listForApi (start: number, count: number, sort: string) { - const query = { - offset: start, - limit: count, - order: [ getSort(sort) ] - } - - return JobModel.findAndCountAll(query).then(({ rows, count }) => { - return { - data: rows, - total: count - } - }) - } - - toFormattedJSON () { - return { - id: this.id, - state: this.state, - category: this.category, - handlerName: this.handlerName, - handlerInputData: this.handlerInputData, - createdAt: this.createdAt, - updatedAt: this.updatedAt - } - } -} -- cgit v1.2.3