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 @@
+import { values } from 'lodash'
+import * as Sequelize from 'sequelize'
+
+import { JOB_STATES } from '../../initializers'
+
+import { addMethodsToModel } from '../utils'
+import {
+  JobClass,
+  JobInstance,
+  JobAttributes,
+
+  JobMethods
+} from './job-interface'
+
+let Job: Sequelize.Model<JobInstance, JobAttributes>
+let listWithLimit: JobMethods.ListWithLimit
+
+export default function defineJob (sequelize: Sequelize.Sequelize, DataTypes: Sequelize.DataTypes) {
+  Job = sequelize.define<JobInstance, JobAttributes>('Job',
+    {
+      state: {
+        type: DataTypes.ENUM(values(JOB_STATES)),
+        allowNull: false
+      },
+      handlerName: {
+        type: DataTypes.STRING,
+        allowNull: false
+      },
+      handlerInputData: {
+        type: DataTypes.JSON,
+        allowNull: true
+      }
+    },
+    {
+      indexes: [
+        {
+          fields: [ 'state' ]
+        }
+      ]
+    }
+  )
+
+  const classMethods = [ listWithLimit ]
+  addMethodsToModel(Job, classMethods)
+
+  return Job
+}
+
+// ---------------------------------------------------------------------------
+
+listWithLimit = function (limit: number, state: string, callback: JobMethods.ListWithLimitCallback) {
+  const query = {
+    order: [
+      [ 'id', 'ASC' ]
+    ],
+    limit: limit,
+    where: {
+      state
+    }
+  }
+
+  return Job.findAll(query).asCallback(callback)
+}