summaryrefslogtreecommitdiff
path: root/lib
diff options
context:
space:
mode:
Diffstat (limited to 'lib')
-rw-r--r--lib/models/index.js31
1 files changed, 31 insertions, 0 deletions
diff --git a/lib/models/index.js b/lib/models/index.js
index e752a993..4558b25e 100644
--- a/lib/models/index.js
+++ b/lib/models/index.js
@@ -4,6 +4,7 @@ const fs = require('fs')
const path = require('path')
const Sequelize = require('sequelize')
const { cloneDeep } = require('lodash')
+const Umzug = require('umzug')
// core
const config = require('../config')
@@ -57,6 +58,36 @@ Object.keys(db).forEach(function (modelName) {
}
})
+const umzug = new Umzug({
+ migrations: {
+ path: path.resolve(__dirname, '..', 'migrations'),
+ params: [
+ sequelize.getQueryInterface(),
+ Sequelize.DataTypes
+ ]
+ },
+ // Required wrapper function required to prevent winstion issue
+ // https://github.com/winstonjs/winston/issues/1577
+ logging: message => {
+ logger.info(message)
+ },
+ storage: 'sequelize',
+ storageOptions: {
+ sequelize: sequelize
+ }
+})
+
+db.runMigrations = async function runMigrations () {
+ // checks migrations and run them if they are not already applied
+ // exit in case of unsuccessful migrations
+ await umzug.up().catch(error => {
+ logger.error(error)
+ logger.error('Database migration failed. Exiting…')
+ process.exit(1)
+ })
+ logger.info('All migrations performed successfully')
+}
+
db.sequelize = sequelize
db.Sequelize = Sequelize