public/mailtrain
1
0
Fork 0
Code Issues Pull requests Releases Wiki Activity

Check schema version before starting

Browse source
This commit is contained in:
Andris Reinman 2016-04-20 20:29:29 +03:00
parent ed7bef48ec
commit f213f8ba65
2 changed files with 17 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
config/default.toml
View file

@ -34,6 +34,8 @@ database="mailtrain"
charset="utf8mb4" charset="utf8mb4"
# enter path for mysql command line application # enter path for mysql command line application
command="mysql" command="mysql"
# required database schema version
schema_version=1
[redis] [redis]
# enable to use Redis session cache or disable if Redis is not installed # enable to use Redis session cache or disable if Redis is not installed

16
index.js
View file

@ -12,6 +12,7 @@ let sender = require('./services/sender');
let importer = require('./services/importer'); // eslint-disable-line global-require let importer = require('./services/importer'); // eslint-disable-line global-require
let verpServer = require('./services/verp-server'); // eslint-disable-line global-require let verpServer = require('./services/verp-server'); // eslint-disable-line global-require
let testServer = require('./services/test-server'); // eslint-disable-line global-require let testServer = require('./services/test-server'); // eslint-disable-line global-require
let settings = require('./lib/models/settings');
let port = config.www.port; let port = config.www.port;
let host = config.www.host; let host = config.www.host;
@ -33,7 +34,20 @@ let server = http.createServer(app);
* Listen on provided port, on all network interfaces. * Listen on provided port, on all network interfaces.
*/ */
server.listen(port, host); settings.list(['db_schema_version'], (err, configItems) => {
if (err) {
throw err;
}
let dbSchemaVersion = Number(configItems.dbSchemaVersion) || 0;
if (dbSchemaVersion < config.mysql.schema_version) {
log.error('Database', 'Database schema outdated. Run `npm run sql` to upgrade');
return process.exit(1);
}
server.listen(port, host);
});
server.on('error', err => { server.on('error', err => {
if (err.syscall !== 'listen') { if (err.syscall !== 'listen') {