feat: locales remote fetch+ deps update + fixes

server/core/queue.js

@@ -1,23 +1,40 @@
+const path = require('path')
 const Bull = require('bull')
 const Promise = require('bluebird')
+const _ = require('lodash')
 
 /* global WIKI */
 
 module.exports = {
+  job: {},
   init() {
-    WIKI.data.queues.forEach(queueName => {
-      this[queueName] = new Bull(queueName, {
-        prefix: `q-${WIKI.config.ha.nodeuid}`,
+    _.forOwn(WIKI.data.jobs, (queueParams, queueName) => {
+      this.job[queueName] = new Bull(queueName, {
+        prefix: `q-${WIKI.config.ha.uid}`,
         redis: WIKI.config.redis
       })
+      this.job[queueName].process(path.join(WIKI.SERVERPATH, `jobs/${_.kebabCase(queueName)}.js`))
     })
     return this
   },
-  clean() {
-    return Promise.each(WIKI.data.queues, queueName => {
+  start() {
+    _.forOwn(WIKI.data.jobs, (queueParams, queueName) => {
+      if (queueParams.onInit) {
+        this.job[queueName].add({}, {
+          removeOnComplete: true
+        })
+      }
+      this.job[queueName].add({}, {
+        repeat: { cron: queueParams.cron },
+        removeOnComplete: true
+      })
+    })
+  },
+  async clean() {
+    return Promise.each(_.keys(WIKI.data.jobs), queueName => {
       return new Promise((resolve, reject) => {
         let keyStream = WIKI.redis.scanStream({
-          match: `q-${WIKI.config.ha.nodeuid}:${queueName}:*`
+          match: `q-${WIKI.config.ha.uid}:${queueName}:*`
         })
         keyStream.on('data', resultKeys => {
           if (resultKeys.length > 0) {