1 | 'use strict';
|
2 |
|
3 | Object.defineProperty(exports, "__esModule", {
|
4 | value: true
|
5 | });
|
6 | exports.default = undefined;
|
7 |
|
8 | var _setImmediate2 = require('babel-runtime/core-js/set-immediate');
|
9 |
|
10 | var _setImmediate3 = _interopRequireDefault(_setImmediate2);
|
11 |
|
12 | var _getPrototypeOf = require('babel-runtime/core-js/object/get-prototype-of');
|
13 |
|
14 | var _getPrototypeOf2 = _interopRequireDefault(_getPrototypeOf);
|
15 |
|
16 | var _classCallCheck2 = require('babel-runtime/helpers/classCallCheck');
|
17 |
|
18 | var _classCallCheck3 = _interopRequireDefault(_classCallCheck2);
|
19 |
|
20 | var _createClass2 = require('babel-runtime/helpers/createClass');
|
21 |
|
22 | var _createClass3 = _interopRequireDefault(_createClass2);
|
23 |
|
24 | var _possibleConstructorReturn2 = require('babel-runtime/helpers/possibleConstructorReturn');
|
25 |
|
26 | var _possibleConstructorReturn3 = _interopRequireDefault(_possibleConstructorReturn2);
|
27 |
|
28 | var _inherits2 = require('babel-runtime/helpers/inherits');
|
29 |
|
30 | var _inherits3 = _interopRequireDefault(_inherits2);
|
31 |
|
32 | var _stream = require('stream');
|
33 |
|
34 | var _lodash = require('lodash');
|
35 |
|
36 | var _lodash2 = _interopRequireDefault(_lodash);
|
37 |
|
38 | var _defaults = require('./defaults');
|
39 |
|
40 | var defaults = _interopRequireWildcard(_defaults);
|
41 |
|
42 | var _logger = require('./logger');
|
43 |
|
44 | var _logger2 = _interopRequireDefault(_logger);
|
45 |
|
46 | function _interopRequireWildcard(obj) { if (obj && obj.__esModule) { return obj; } else { var newObj = {}; if (obj != null) { for (var key in obj) { if (Object.prototype.hasOwnProperty.call(obj, key)) newObj[key] = obj[key]; } } newObj.default = obj; return newObj; } }
|
47 |
|
48 | function _interopRequireDefault(obj) { return obj && obj.__esModule ? obj : { default: obj }; }
|
49 |
|
50 | var BunyanStream = function (_Writable) {
|
51 | (0, _inherits3.default)(BunyanStream, _Writable);
|
52 |
|
53 | function BunyanStream(opts) {
|
54 | (0, _classCallCheck3.default)(this, BunyanStream);
|
55 |
|
56 | var _this = (0, _possibleConstructorReturn3.default)(this, (BunyanStream.__proto__ || (0, _getPrototypeOf2.default)(BunyanStream)).call(this, {
|
57 | objectMode: true
|
58 | }));
|
59 |
|
60 | var loggerOpts = _lodash2.default.clone(opts || {});
|
61 |
|
62 | loggerOpts.timestamp = false;
|
63 | loggerOpts.levels = opts.levels || defaults.bunyanLevels;
|
64 |
|
65 | _this.logger = new _logger2.default(loggerOpts);
|
66 |
|
67 | _this.logger.on('error', function (err) {
|
68 | return _this.emit(err);
|
69 | });
|
70 | return _this;
|
71 | }
|
72 |
|
73 | (0, _createClass3.default)(BunyanStream, [{
|
74 | key: '_write',
|
75 | value: function _write(log, enc, cb) {
|
76 | var lvl = log.level / 10 - 1;
|
77 |
|
78 | this.logger.log(lvl, log);
|
79 |
|
80 | (0, _setImmediate3.default)(cb);
|
81 | }
|
82 | }, {
|
83 | key: 'logger',
|
84 | get: function get() {
|
85 | return this._logger;
|
86 | },
|
87 | set: function set(obj) {
|
88 | this._logger = obj;
|
89 | }
|
90 | }]);
|
91 | return BunyanStream;
|
92 | }(_stream.Writable);
|
93 |
|
94 | exports.default = BunyanStream;
|
95 | module.exports = exports['default'];
|
96 |
|