summaryrefslogtreecommitdiff
path: root/lib/worker/index.js
diff options
context:
space:
mode:
Diffstat (limited to 'lib/worker/index.js')
-rw-r--r--lib/worker/index.js7
1 files changed, 5 insertions, 2 deletions
diff --git a/lib/worker/index.js b/lib/worker/index.js
index 52f12e2..6733dd1 100644
--- a/lib/worker/index.js
+++ b/lib/worker/index.js
@@ -1,15 +1,16 @@
require('dotenv').config()
const ipc = require('node-ipc')
-const db = require('../db')
-const dbFile = db.crud(db.File)
const processFiles = require('./processFiles')
+const processTask = require('./processTask')
ipc.config.id = 'cortexworker'
ipc.config.retry = 1500
+ipc.config.silent = true
processFiles()
+processTask()
ipc.connectTo('cortex', () => {
ipc.of.cortex.on('connect', () => {
@@ -28,8 +29,10 @@ ipc.connectTo('cortex', () => {
})
ipc.of.cortex.on('job', (data) => {
ipc.log('received job: '.debug, data);
+ processTask()
})
ipc.of.cortex.on('task', (data) => {
ipc.log('received task: '.debug, data);
+ processTask()
})
})