workers logic

logparser-server-workers.js

  // ##############################################
  // WORKERS
} else if (process.env.WorkerName === 'readlogs') {
  console.log('👉🏽  Worker readlogs ' + process.pid + ' has started.')
  process.on('message', async ({logfiles}) => {
    try {
      const read = await readLogFiles.parseFiles(logfiles)
      process.send({read, logfiles})
    } catch (e) {
      console.log(`something went wrong with reading logs => ${e}`)
      process.exit(0)
    }
  })
} else if (process.env.WorkerName === 'savelogs') {
  console.log('👉🏽  Worker savelogs ' + process.pid + ' has started.')
  process.on('message', async ({read, collection}) => {
    try {
      const save = await saveToDB.saveToDB(read, collection)
      console.log(`RECORDS SAVED IN ${collection} => ${save.reduce((prev, cur) => prev + cur, 0)}  🤙`)
    } catch (e) {
      console.log(`something went wrong with saving parsed logs => ${e}`)
      process.exit(0)
    }
  })
} else if (process.env.WorkerName === 'deletelogs') {
  console.log('👉🏽  Worker deletelogs ' + process.pid + ' has started. ')
  process.on('message', async ({logfiles, type}) => {
    try {
      const deleted = await moveAndDelete.deleteFiles(logfiles)
      console.log(`LOCAL LOGS DELETED => ${deleted.length}`)
    } catch (e) {
      console.log(`something went wrong with deleting local logs => ${e}`)
      process.exit(0)
    }
  })
} else if (process.env.WorkerName === 'movelogs') {
  console.log('👉🏽  Worker movelogs ' + process.pid + ' has started.')
  process.on('message', async ({logfiles}) => {
    try {
      moveAndDelete.renameFiles(logfiles)
        .then(async moved => console.log(`REMOTE LOGS MOVED =>`, await moved.length))
    } catch (e) {
      console.log(`something went wrong with moving remote logs => ${e}`)
      process.exit(0)
    }
  })
} else if (process.env.WorkerName === 'geolocation') {
  console.log('👉🏽  Worker geolocation ' + process.pid + ' has started.')
  process.on('message', async (read) => {
    try {
      geoip.getLocations(read)
        .then(async locations => process.send(locations))
    } catch (e) {
      console.log(`something went wrong locating ips => ${e}`)
      process.exit(0)
    }
  })
}