const _ = require('lodash') const EventEmitter = require('eventemitter2').EventEmitter2 /* global WIKI */ module.exports = { async init() { WIKI.logger.info('=======================================') WIKI.logger.info(`= Wiki.js ${_.padEnd(WIKI.version + ' ', 29, '=')}`) WIKI.logger.info('=======================================') WIKI.logger.info('Initializing...') WIKI.models = require('./db').init() try { await WIKI.models.onReady await WIKI.configSvc.loadFromDb() await WIKI.configSvc.applyFlags() } catch (err) { WIKI.logger.error('Database Initialization Error: ' + err.message) if (WIKI.IS_DEBUG) { console.error(err) } process.exit(1) } this.bootMaster() }, /** * Pre-Master Boot Sequence */ async preBootMaster() { try { await this.initTelemetry() WIKI.cache = require('./cache').init() WIKI.scheduler = require('./scheduler').init() WIKI.servers = require('./servers') WIKI.sideloader = require('./sideloader').init() WIKI.events = { inbound: new EventEmitter(), outbound: new EventEmitter() } } catch (err) { WIKI.logger.error(err) process.exit(1) } }, /** * Boot Master Process */ async bootMaster() { try { if (WIKI.config.setup) { WIKI.logger.info('Starting setup wizard...') require('../setup')() } else { await this.preBootMaster() await require('../master')() this.postBootMaster() } } catch (err) { WIKI.logger.error(err) process.exit(1) } }, /** * Post-Master Boot Sequence */ async postBootMaster() { await WIKI.models.analytics.refreshProvidersFromDisk() await WIKI.models.authentication.refreshStrategiesFromDisk() await WIKI.models.editors.refreshEditorsFromDisk() await WIKI.models.loggers.refreshLoggersFromDisk() await WIKI.models.renderers.refreshRenderersFromDisk() await WIKI.models.searchEngines.refreshSearchEnginesFromDisk() await WIKI.models.storage.refreshTargetsFromDisk() await WIKI.auth.activateStrategies() await WIKI.models.searchEngines.initEngine() await WIKI.models.storage.initTargets() WIKI.scheduler.start() await WIKI.models.subscribeToNotifications() }, /** * Init Telemetry */ async initTelemetry() { require('./telemetry').init() process.on('unhandledRejection', (err) => { WIKI.logger.warn(err) WIKI.telemetry.sendError(err) }) process.on('uncaughtException', (err) => { WIKI.logger.warn(err) WIKI.telemetry.sendError(err) }) }, /** * Graceful shutdown */ async shutdown () { if (WIKI.models) { await WIKI.models.unsubscribeToNotifications() await WIKI.models.knex.client.pool.destroy() await WIKI.models.knex.destroy() } if (WIKI.scheduler) { WIKI.scheduler.stop() } if (WIKI.servers) { await WIKI.servers.stopServers() } } }