1 files changed, 32 insertions, 0 deletions
diff --git a/lib/worker/index.js b/lib/worker/index.js
new file mode 100644
index 0000000..604756b
--- /dev/null
+++ b/lib/worker/index.js
@@ -0,0 +1,32 @@
+require('dotenv').config()
+
+const ipc = require('node-ipc')
+const db = require('../db')
+const dbFile = db.crud(db.File)
+
+const processFiles = require('./processFiles')
+
+ipc.config.id = 'cortexworker'
+ipc.config.retry = 1500
+
+processFiles()
+
+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.of.cortex.on('process', (data) => {
+    ipc.log('received process: '.debug, data);
+    processFiles()
+  })
+  ipc.of.cortex.on('job', (data) => {
+    ipc.log('received job: '.debug, data);
+  })
+})