index.js

'use strict';

const winston = require('winston');
const TransportStream = require('winston-transport');
const { LEVEL, MESSAGE } = require('triple-beam');

/**
 * Transport for reporting errors to newrelic.
 * @type {Newrelic}
 * @extends {TransportStream}
 */
module.exports = class Newrelic extends TransportStream {
    /**
     * Constructor function for the Console transport object responsible for
     * persisting log messages and metadata to a terminal or TTY.
     * @param {!Object} [options={}] - Options for this instance.
     */
    constructor(options = {}) {
        const env = options.env || process.env.NODE_ENV;
        super(options);
        this.newrelic = require('./newrelicHelper')(env);
        this.name = 'newrelic-winston';
    }

    /**
     *
     * @param {Object} info
     * @param {function} callback
     */
    log(info, callback) {
        setImmediate(() => this.emit('logged', info));

        if (info[LEVEL] === 'error') {
            this.newrelic.noticeError(info[MESSAGE], typeof info.message === 'object' && info.message);
        }

        callback();
    }
};