wikijs/server/worker.js

'use strict'

/* global wiki */

const path = require('path')

wiki.REPOPATH = path.resolve(wiki.ROOTPATH, wiki.config.paths.repo)
wiki.DATAPATH = path.resolve(wiki.ROOTPATH, wiki.config.paths.data)
wiki.UPLTEMPPATH = path.join(wiki.DATAPATH, 'temp-upload')

// ----------------------------------------
// Load global modules
// ----------------------------------------

// wiki.upl = require('./modules/uploads-agent').init()
// wiki.git = require('./modules/git').init()
// wiki.entries = require('./modules/entries').init()
wiki.lang = require('i18next')
wiki.mark = require('./modules/markdown')

// ----------------------------------------
// Load local modules
// ----------------------------------------

const Promise = require('bluebird')
const i18nBackend = require('i18next-node-fs-backend')

// ----------------------------------------
// Localization Engine
// ----------------------------------------

wiki.lang.use(i18nBackend).init({
  load: 'languageOnly',
  ns: ['common', 'admin', 'auth', 'errors', 'git'],
  defaultNS: 'common',
  saveMissing: false,
  preload: [wiki.config.lang],
  lng: wiki.config.lang,
  fallbackLng: 'en',
  backend: {
    loadPath: path.join(wiki.SERVERPATH, 'locales/{{lng}}/{{ns}}.json')
  }
})

// ----------------------------------------
// Start Queues
// ----------------------------------------

const Bull = require('bull')
const autoload = require('auto-load')

let queues = autoload(path.join(wiki.SERVERPATH, 'queues'))

Promise.join(
  wiki.db.onReady
  // wiki.upl.initialScan()
).then(() => {
  for (let queueName in queues) {
    new Bull(queueName, { redis: wiki.config.redis }).process(queues[queueName])
  }
})

// ----------------------------------------
// Shutdown gracefully
// ----------------------------------------

process.on('disconnect', () => {
  wiki.logger.warn('Lost connection to Master. Exiting...')
  process.exit()
})