@testim/testim-cli/lib/coralogix-bunyan.stream.js

"use strict";


// 
// This is copied from coralogix-bunyan-stream pacakge and altered to expose waitForFlush
// 


var coralogix_logger_1 = require("coralogix-logger");
var sev_map = {
    10: coralogix_logger_1.Severity.debug,
    30: coralogix_logger_1.Severity.info,
    40: coralogix_logger_1.Severity.warning,
    50: coralogix_logger_1.Severity.error,
    60: coralogix_logger_1.Severity.critical,
    20: coralogix_logger_1.Severity.debug
};
var CoralogixStream = (function () {
    function CoralogixStream(options) {
        if (!options)
            options = {};
        CoralogixStream.logger = this.logger = new coralogix_logger_1.CoralogixLogger(options.category);
    }
    CoralogixStream.waitForFlush = function() {
        return CoralogixStream.logger.waitForFlush();
    }
    CoralogixStream.prototype.write = function (rec) {
        var log = new coralogix_logger_1.Log();
        log.severity = sev_map[rec.level];
        log.category = rec.category;
        if (rec.className)
            log.className = rec.className;
        if (rec.methodName)
            log.methodName = rec.methodName;
        if (rec.threadId)
            log.threadId = rec.threadId;
        log.text = this.removeStaticFields(rec);
        this.logger.addLog(log);
    };
    CoralogixStream.prototype.removeStaticFields = function (json) {
        delete json.threadId;
        delete json.methodName;
        delete json.className;
        delete json.category;
        return JSON.stringify(json, this.replaceErrors);
    };
    CoralogixStream.prototype.replaceErrors = function (key, value) {
        if (value instanceof Error) {
            var error = {};
            Object.getOwnPropertyNames(value).forEach(function (key) {
                error[key] = value[key];
            });
            return error;
        }
        return value;
    };
    CoralogixStream.configure = function (config) {
        coralogix_logger_1.CoralogixLogger.configure(config);
    };
    return CoralogixStream;
}());
module.exports = { CoralogixStream }