@opentribe/packages_logger/index.js

const path = require('path');
const uuid = require("node-uuid");
const logger = require('npmlog');
const colors = require('colors/safe');

//this is a little weird, it's some old code i found from an unmaintained lib. 
//i took the chunk i needed, a function that converts an object to a valid heroku log string.
const HerokuLogger = require('./dep-heroku.js');
const Analytics = require('./analytics/');

logger.prefixStyle = {
  bg: 'blue',
  fg: 'white'
};

const _replace_buffer = (args) => args.map(arg => {
  const not_a_buffer = (
    !Buffer.isBuffer(arg) &&
    !(arg && typeof arg === 'object' && arg.type === 'Buffer')
  );
  if (not_a_buffer) {
    return arg
  }
  return 'BUFFER'
})

//iterates through the error stack, 
//and pulls out the file matching the file of the caller
const _get_caller_file_line = (type) => {
  try {
    let err = new Error();
    let caller_data;
    let current_data;
    let call_stack = [];
    Error.prepareStackTrace = function (err, stack) { return stack; };
    let outer_shifted = err.stack.shift();
    current_data = {
			file: outer_shifted.getFileName().split(path.resolve(__dirname, '..', '..'))[1],
			line: outer_shifted.getLineNumber()
		};
    let count = 0;
    while (err.stack.length) {
      let shifted = err.stack.shift();
      caller_data = {
				file: _shorten_file_path(shifted.getFileName()),
				line: shifted.getLineNumber()
			};
      if(current_data.file !== caller_data.file) {
        if (type === 'string') {
          return current_data.file + '::' + current_data.line
        }
        return caller_data
      }
    }
  } catch (err) {}
  return undefined;
};

let remote;

exports.init_remote = (_remote) => {
  remote = _remote;
};

exports.process_errors = (on_error) => {
  process.on('unhandledRejection', (reason, promise) => {
    on_error(reason);
  });
  process.on('uncaughtException', (err) => {
    on_error(err);
  });
};

exports.json = json => logger.info('data', JSON.stringify(json, null, 2));

exports.cli = log => {
  const caller_data = _get_caller_file_line('string');
  logger.info(caller_data, log);
}

exports.color = (color, log) => console.log(colors[color](log_two));

exports.analytics = Analytics;

exports.heroku = {
  //[priority low, medium, high]
  exception: (message, priority, optional_payload) => {
    if (priority !== 'low' && priority !== 'medium' && priority !== 'high') {
      priority = 'low'
    }
    const caller_data = _get_caller_file_line();
    console.log(HerokuLogger.log('system_exception', Object.assign({}, caller_data, { message, priority }, optional_payload && { payload: JSON.stringify(optional_payload, ...(remote === 'development' ? [null, 2] : [])) } || null)));
  },
  basic_info_logger: (message) => {
    console.log(HerokuLogger.log('basic', { data: message }));
  },
  worker_info: (message, obj) => {
    console.log(HerokuLogger.log('worker:' + process.pid + ' message: ' + message, obj));
  },
  worker_succeeded: (domain, method, args) => {
    args = _replace_buffer(args);
    console.log(HerokuLogger.log('worker_succeeded', {
      args: remote !== 'development' ? JSON.stringify(args) : JSON.stringify(args, null, 2),
      timestamp: Date.now(),
      domain,
      method
    }));
  },
  worker_failed: (domain, method, args) => {
    args = _replace_buffer(args);
    console.log(HerokuLogger.log('worker_failed', {
      args: remote !== 'development' ? JSON.stringify(args) : JSON.stringify(args, null, 2),
      timestamp: Date.now(),
      domain,
      method
    }));
  },
  service_events_success_logger: (service, args) => {
    args = _replace_buffer(args);
    console.log(HerokuLogger.log('service_succeeded', { 
      timestamp: Date.now(),
      args: remote !== 'development' ? JSON.stringify(args) : JSON.stringify(args, null, 2), 
      service 
    }));
  },
  service_events_error_logger: (service, args) => {
    args = _replace_buffer(args);
    console.log(HerokuLogger.log('service_failed', {
      timestamp: Date.now(),
       args: remote !== 'development' ? JSON.stringify(args) : JSON.stringify(args, null, 2), 
       service 
     }));
  },
};