index.js

const Pino = require('pino')
const spawn = require('child_process').spawn
const { MONGO_ADDRESS } = process.env

function eventLogger () {
  const mongoLog = spawnMongoLog()
  mongoLog.on('error', err => { throw err })
  mongoLog.stdout.pipe(process.stdout)

  const pino = Pino({
    name: 'letzdoit-events',
    level: 'info'
  }, mongoLog.stdin)

  return pino
}

function spawnMongoLog () {
  return spawn(
    './node_modules/.bin/pino-mongodb',
    [
      '--host', MONGO_ADDRESS,
      '--collection', 'logs'
    ]
  )
}

module.exports = eventLogger