blob: 6733dd1c6686480682635ef7a46f49afb512b92d (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
|
require('dotenv').config()
const ipc = require('node-ipc')
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', () => {
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);
processTask()
})
ipc.of.cortex.on('task', (data) => {
ipc.log('received task: '.debug, data);
processTask()
})
})
|
