0db862f3c9
This commit removes the need for separate migrations with the sequelize-cli by running them with umzug on application startup. This is a port of #384 Co-authored-by: Sheogorath <sheogorath@shivering-isles.com> Signed-off-by: David Mehren <git@herrmehren.de>
95 lines
2.3 KiB
JavaScript
95 lines
2.3 KiB
JavaScript
'use strict'
|
|
// external modules
|
|
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')
|
|
const logger = require('../logger')
|
|
|
|
const dbconfig = cloneDeep(config.db)
|
|
dbconfig.logging = config.debug
|
|
? (data) => {
|
|
logger.info(data)
|
|
}
|
|
: false
|
|
|
|
let sequelize = null
|
|
|
|
// Heroku specific
|
|
if (config.dbURL) {
|
|
sequelize = new Sequelize(config.dbURL, dbconfig)
|
|
} else {
|
|
sequelize = new Sequelize(dbconfig.database, dbconfig.username, dbconfig.password, dbconfig)
|
|
}
|
|
|
|
// [Postgres] Handling NULL bytes
|
|
// https://github.com/sequelize/sequelize/issues/6485
|
|
function stripNullByte (value) {
|
|
value = '' + value
|
|
// eslint-disable-next-line no-control-regex
|
|
return value ? value.replace(/\u0000/g, '') : value
|
|
}
|
|
sequelize.stripNullByte = stripNullByte
|
|
|
|
function processData (data, _default, process) {
|
|
if (data === undefined) return data
|
|
else return data === null ? _default : (process ? process(data) : data)
|
|
}
|
|
sequelize.processData = processData
|
|
|
|
const db = {}
|
|
|
|
fs.readdirSync(__dirname)
|
|
.filter(function (file) {
|
|
return (file.indexOf('.') !== 0) && (file !== 'index.js')
|
|
})
|
|
.forEach(function (file) {
|
|
const model = sequelize.import(path.join(__dirname, file))
|
|
db[model.name] = model
|
|
})
|
|
|
|
Object.keys(db).forEach(function (modelName) {
|
|
if ('associate' in db[modelName]) {
|
|
db[modelName].associate(db)
|
|
}
|
|
})
|
|
|
|
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
|
|
|
|
module.exports = db
|