index.js

'use strict'

const pinoPapertrail = require('./lib/pino-papertrail')
const pumpify = require('pumpify')

const defaultOptions = {
  appname: 'pino',
  echo: true,
  host: 'localhost',
  port: '1234',
  connection: 'udp',
  'message-only': false
}

module.exports.createWriteStream = (opts) => {
  const { appname, echo, host, port, connection, 'message-only': messageOnly } = { ...defaultOptions, ...opts }

  const parseJson = pinoPapertrail.parseJson()
  const toSyslog = pinoPapertrail.toSyslog({ appname, 'message-only': messageOnly })
  const papertrail = pinoPapertrail.toPapertrail({ echo, port, host, connection })

  return pumpify(parseJson, toSyslog, papertrail)
}