'use strict'; const logger = require('./lib/logger'); const migrator = require('./migrator'); const DEFAULT_OPTIONS = { databaseUri: process.env.DATABASE_URL || 'postgres://unleash_user:passord@localhost:5432/unleash', port: process.env.HTTP_PORT || process.env.PORT || 4242, baseUriPath: process.env.BASE_URI_PATH || '', }; function createApp (options) { const db = require('./lib/db/db-pool')(options.databaseUri); // Database dependecies (statefull) const { eventStore, featureToggleStore, strategyStore, clientInstancesDb, clientMetricsDb, clientStrategiesDb, } = require('./lib/db')(db); const config = { baseUriPath: options.baseUriPath, port: options.port, publicFolder: options.publicFolder, db, eventStore, featureToggleStore, strategyStore, clientMetricsDb, clientStrategiesDb, clientInstancesDb, }; const app = require('./app')(config); const server = app.listen(app.get('port'), () => { logger.info(`Unleash started on ${app.get('port')}`); }); return { app, server }; } function start (opts) { const options = Object.assign({}, DEFAULT_OPTIONS, opts); if (!options.databaseUri) { throw new Error('You must either pass databaseUri option or set environemnt variable DATABASE_URL'); } return migrator(options.databaseUri) .then(() => createApp(options)) .catch(err => logger.error('failed to migrate db', err)); } process.on('uncaughtException', err => { logger.error('Uncaught Exception:', err.message); logger.error(err.stack); }); module.exports = { start, };