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