aboutsummaryrefslogtreecommitdiffhomepage
path: root/server/models/job/job.ts
diff options
context:
space:
mode:
Diffstat (limited to 'server/models/job/job.ts')
-rw-r--r--server/models/job/job.ts63
1 files changed, 63 insertions, 0 deletions
diff --git a/server/models/job/job.ts b/server/models/job/job.ts
new file mode 100644
index 000000000..60a6c551b
--- /dev/null
+++ b/server/models/job/job.ts
@@ -0,0 +1,63 @@
1import { values } from 'lodash'
2import * as Sequelize from 'sequelize'
3
4import { JOB_STATES } from '../../initializers'
5
6import { addMethodsToModel } from '../utils'
7import {
8 JobClass,
9 JobInstance,
10 JobAttributes,
11
12 JobMethods
13} from './job-interface'
14
15let Job: Sequelize.Model<JobInstance, JobAttributes>
16let listWithLimit: JobMethods.ListWithLimit
17
18export default function defineJob (sequelize: Sequelize.Sequelize, DataTypes: Sequelize.DataTypes) {
19 Job = sequelize.define<JobInstance, JobAttributes>('Job',
20 {
21 state: {
22 type: DataTypes.ENUM(values(JOB_STATES)),
23 allowNull: false
24 },
25 handlerName: {
26 type: DataTypes.STRING,
27 allowNull: false
28 },
29 handlerInputData: {
30 type: DataTypes.JSON,
31 allowNull: true
32 }
33 },
34 {
35 indexes: [
36 {
37 fields: [ 'state' ]
38 }
39 ]
40 }
41 )
42
43 const classMethods = [ listWithLimit ]
44 addMethodsToModel(Job, classMethods)
45
46 return Job
47}
48
49// ---------------------------------------------------------------------------
50
51listWithLimit = function (limit: number, state: string, callback: JobMethods.ListWithLimitCallback) {
52 const query = {
53 order: [
54 [ 'id', 'ASC' ]
55 ],
56 limit: limit,
57 where: {
58 state
59 }
60 }
61
62 return Job.findAll(query).asCallback(callback)
63}