require('dotenv').config()

const ipc = require('node-ipc')

const processFiles = require('./processFiles')
const processTasks = require('./processTasks')

ipc.config.id = 'cortexworker'
ipc.config.retry = 1500
ipc.config.silent = true

processFiles()
processTasks()

ipc.connectTo('cortex', () => {
  ipc.of.cortex.on('connect', () => {
    ipc.log('## connected to cortex ##', ipc.config.delay);
  })
  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('processFiles', (data) => {
    ipc.log('>>> received processFiles'.debug, data);
    processFiles()
  })
  ipc.of.cortex.on('job', (data) => {
    ipc.log('received job'.debug, data);
    processTasks()
  })
  ipc.of.cortex.on('processTasks', (data) => {
    ipc.log('>>> received processTasks: '.debug, data);
    processTasks()
  })
})