From 64e8c03dea044752bf3f2f228462721fe565f950 Mon Sep 17 00:00:00 2001 From: Jules Laplace Date: Wed, 19 Jul 2017 00:50:05 +0200 Subject: refactor all the worker stuff --- lib/worker/index.js | 7 +++++-- 1 file changed, 5 insertions(+), 2 deletions(-) (limited to 'lib/worker/index.js') 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() }) }) -- cgit v1.2.3-70-g09d2