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()
  })
})