all async paths working

1 files changed, 10 insertions, 11 deletions

diff --git a/lib/worker/index.js b/lib/worker/index.js
index 6733dd1..0e2ff44 100644
--- a/lib/worker/index.js
+++ b/lib/worker/index.js
@@ -3,36 +3,35 @@ require('dotenv').config()
 const ipc = require('node-ipc')
 
 const processFiles = require('./processFiles')
-const processTask = require('./processTask')
+const processTasks = require('./processTasks')
 
 ipc.config.id = 'cortexworker'
 ipc.config.retry = 1500
 ipc.config.silent = true
 
 processFiles()
-processTask()
+processTasks()
 
 ipc.connectTo('cortex', () => {
   ipc.of.cortex.on('connect', () => {
     ipc.log('## connected to cortex ##', ipc.config.delay);
-    // ipc.of.cortex.emit('message', 'hello')
   })
   ipc.of.cortex.on('disconnect', () => {
     ipc.log('disconnected'.notice)
   })
   ipc.of.cortex.on('message', (data) => {
-    ipc.log('received message!'.debug, data)
+    ipc.log('received message'.debug, data)
   })
-  ipc.of.cortex.on('process', (data) => {
-    ipc.log('received process: '.debug, data);
+  ipc.of.cortex.on('processFiles', (data) => {
+    ipc.log('>>> received processFiles'.debug, data);
     processFiles()
   })
   ipc.of.cortex.on('job', (data) => {
-    ipc.log('received job: '.debug, data);
-    processTask()
+    ipc.log('received job'.debug, data);
+    processTasks()
   })
-  ipc.of.cortex.on('task', (data) => {
-    ipc.log('received task: '.debug, data);
-    processTask()
+  ipc.of.cortex.on('processTasks', (data) => {
+    ipc.log('>>> received processTasks: '.debug, data);
+    processTasks()
   })
 })