@gaoding/hlg-logger-v2/logger.js

const logLevel = require('./lib/log-level');
const logFormatter = require('./lib/log-formater');
const metricFormatter = require('./lib/metric-formatter');
const sender = require('./lib/sender');
const util = require('util');

class Logger {
  constructor(config) {
    this._config = Object.assign({
      debug: false,
      logLevel: logLevel.ALL,
    }, config);

    this._logs = []
    this._metrics = [];

    process.on('beforeExit', () => {
      if (0 < this._metrics.length) {
        this._flushMetrics();
      }
    });
  }

  async debug(message, metadata = {}, type = '', module = '') {
    await this.log(logLevel.DEBUG, message, metadata, type, module);
  }

  async info(message, metadata = {}, type = '', module = '') {
    await this.log(logLevel.INFO, message, metadata, type, module);
  }

  async warn(message, metadata = {}, type = '', module = '') {
    await this.log(logLevel.WARN, message, metadata, type, module);
  }

  async error(message, metadata = {}, type = '', module = '') {
    await this.log(logLevel.ERROR, message, metadata, type, module);
  }

  async log(level, message, metadata, type, module) {
    if (logLevel.checkLevelEnabled(this._config.logLevel, level) === false) {
      return false;
    }

    this._logs.push(logFormatter.formatLog(level, message, metadata, type, module));

    await this._flushLogs();
  }

  async _flushLogs() {
    const logs = logFormatter.formatLogs(this._config.logApp, this._logs);

    try {
      throw new Error('test');
      const res = await sender.sendToServer(this._config.logServer, logs);
      this._outputDebug('[hlg-logger-v2] flush logs success: %s', res);
    } catch (err) {
      this._outputDebug('[hlg-logger-v2] flush logs error: %s', err);
    }

    this._logs = [];
  }

  async addMetric(name, target, labels = {}) {
    this._metrics.push(metricFormatter.formatMetric(name, target, labels));

    if (5 <= this._metrics.length) {
      await this._flushMetrics();
    }
  }

  async _flushMetrics() {
    const metrics = metricFormatter.formatMetrics(this._config.metricApp, this._metrics);

    try {
      const res = await sender.sendToServer(this._config.metricServer, metrics);
      this._outputDebug('[hlg-logger-v2] flush logs success: %s', res);
    } catch (err) {
      this._outputDebug('[hlg-logger-v2] flush metrics error: %s', err);
    }

    this._metrics = [];
  }

  _outputDebug(message, ...args) {
    if (this._config.debug) {
      args = args.map((arg) => {
        if (arg instanceof Error) {
          return JSON.stringify({
            code: arg.code || '',
            status: arg.status || 0,
            message: arg.message || '',
            stack: arg.stack || '',
          });
        } else if (arg instanceof Object) {
          return JSON.stringify(arg);
        }
        return arg;
      });

      console.debug(util.format(message, args));
    }
  }
}

module.exports = Logger;