3rdeden

chjj

indexzero

jcrugzz

dabh

w-b-t

maverick18722

winston

 * http.js: Transport for outputting to a json-rpcserver.

function _classCallCheck(instance, Constructor) { if (!(instance instanceof Constructor)) { throw new TypeError("Cannot call a class as a function"); } }

function _defineProperties(target, props) { for (var i = 0; i < props.length; i++) { var descriptor = props[i]; descriptor.enumerable = descriptor.enumerable || false; descriptor.configurable = true; if ("value" in descriptor) descriptor.writable = true; Object.defineProperty(target, _toPropertyKey(descriptor.key), descriptor); } }

function _createClass(Constructor, protoProps, staticProps) { if (protoProps) _defineProperties(Constructor.prototype, protoProps); if (staticProps) _defineProperties(Constructor, staticProps); Object.defineProperty(Constructor, "prototype", { writable: false }); return Constructor; }

function _toPropertyKey(t) { var i = _toPrimitive(t, "string"); return "symbol" == _typeof(i) ? i : String(i); }

function _toPrimitive(t, r) { if ("object" != _typeof(t) || !t) return t; var e = t[Symbol.toPrimitive]; if (void 0 !== e) { var i = e.call(t, r || "default"); if ("object" != _typeof(i)) return i; throw new TypeError("@@toPrimitive must return a primitive value."); } return ("string" === r ? String : Number)(t); }

function _callSuper(t, o, e) { return o = _getPrototypeOf(o), _possibleConstructorReturn(t, _isNativeReflectConstruct() ? Reflect.construct(o, e || [], _getPrototypeOf(t).constructor) : o.apply(t, e)); }

function _assertThisInitialized(self) { if (self === void 0) { throw new ReferenceError("this hasn't been initialised - super() hasn't been called"); } return self; }

function _getPrototypeOf(o) { _getPrototypeOf = Object.setPrototypeOf ? Object.getPrototypeOf.bind() : function _getPrototypeOf(o) { return o.__proto__ || Object.getPrototypeOf(o); }; return _getPrototypeOf(o); }

function _setPrototypeOf(o, p) { _setPrototypeOf = Object.setPrototypeOf ? Object.setPrototypeOf.bind() : function _setPrototypeOf(o, p) { o.__proto__ = p; return o; }; return _setPrototypeOf(o, p); }

var _require = require('readable-stream'),

var TransportStream = require('winston-transport');

var jsonStringify = require('safe-stable-stringify');

var _require2 = require('safe-stable-stringify'),

 * Transport for outputting to a json-rpc server.

module.exports = /*#__PURE__*/function (_TransportStream) {

   * Constructor function for the Http transport object responsible for

   * persisting log messages and metadata to a terminal or TTY.

   * @param {!Object} [options={}] - Options for this instance.

  // eslint-disable-next-line max-statements

    var options = arguments.length > 0 && arguments[0] !== undefined ? arguments[0] : {};

    _this = _callSuper(this, Http, [options]);

    _this.host = options.host || 'localhost';

    _this.maximumDepth = options.maximumDepth;

    _this.headers = options.headers || {};

    _this.headers['content-type'] = 'application/json';

    _this.batch = options.batch || false;

    _this.batchInterval = options.batchInterval || 5000;

    _this.batchCount = options.batchCount || 10;

   * Core logging method exposed to Winston.

   * @param {Object} info - TODO: add param description.

   * @param {function} callback - TODO: add param description.

    value: function log(info, callback) {

      this._request(info, null, null, function (err, res) {

        if (res && res.statusCode !== 200) {

          err = new Error("Invalid HTTP Status Code: ".concat(res.statusCode));

      // Remark: (jcrugzz) Fire and forget here so requests dont cause buffering

      // and block more requests from happening?

     * Query the transport. Options object is optional.

     * @param {Object} options -  Loggly-like query options for this instance.

     * @param {function} callback - Continuation to respond to when complete.

    value: function query(options, callback) {

      if (typeof options === 'function') {

        params: this.normalizeQuery(options)

      var auth = options.params.auth || null;

      var path = options.params.path || null;

      this._request(options, auth, path, function (err, res, body) {

     * Returns a log stream for this transport. Options object is optional.

     * @param {Object} options - Stream options for this instance.

     * @returns {Stream} - TODO: add return description

      var options = arguments.length > 0 && arguments[0] !== undefined ? arguments[0] : {};

      var jsonStringify = configure(_objectSpread({}, this.maximumDepth && {

      req.end(Buffer.from(jsonStringify(options, this.options.replacer), 'utf8'));

const { Stream } = require('readable-stream');

const TransportStream = require('winston-transport');

const jsonStringify = require('safe-stable-stringify');

const { configure } = require('safe-stable-stringify');

module.exports = class Http extends TransportStream {

    this.host = options.host || 'localhost';

    this.maximumDepth = options.maximumDepth;

    this.headers = options.headers || {};

    this.headers['content-type'] = 'application/json';

    this.batchInterval = options.batchInterval || 5000;

    this.batchCount = options.batchCount || 10;

    this._request(info, null, null, (err, res) => {

      if (res && res.statusCode !== 200) {

        err = new Error(`Invalid HTTP Status Code: ${res.statusCode}`);

    // Remark: (jcrugzz) Fire and forget here so requests dont cause buffering

    // and block more requests from happening?

   * Query the transport. Options object is optional.

   * @param {Object} options -  Loggly-like query options for this instance.

   * @param {function} callback - Continuation to respond to when complete.

      params: this.normalizeQuery(options)

    const auth = options.params.auth || null;

    const path = options.params.path || null;

    this._request(options, auth, path, (err, res, body) => {

   * Returns a log stream for this transport. Options object is optional.

   * @param {Object} options - Stream options for this instance.

   * @returns {Stream} - TODO: add return description

      ...(this.maximumDepth && { maximumDepth: this.maximumDepth })

    req.end(Buffer.from(jsonStringify(options, this.options.replacer), 'utf8'));

// Project: https://github.com/winstonjs/winston

import * as Transport from 'winston-transport';

  interface ConsoleTransportOptions extends Transport.TransportStreamOptions {

  interface ConsoleTransportInstance extends Transport {

    new(options?: ConsoleTransportOptions): ConsoleTransportInstance;

  interface FileTransportOptions extends Transport.TransportStreamOptions {

  interface FileTransportInstance extends Transport {

    new(options?: FileTransportOptions): FileTransportInstance;

  interface HttpTransportOptions extends Transport.TransportStreamOptions {

    auth?: { username?: string | undefined, password?: string | undefined, bearer?: string | undefined };

    replacer?: (key: string, value: any) => any;

  interface HttpTransportInstance extends Transport {

    new(options?: HttpTransportOptions): HttpTransportInstance;

  interface StreamTransportOptions extends Transport.TransportStreamOptions {

  interface StreamTransportInstance extends Transport {

    new(options?: StreamTransportOptions): StreamTransportInstance;

    FileTransportOptions: FileTransportOptions;

    ConsoleTransportOptions: ConsoleTransportOptions;

    HttpTransportOptions: HttpTransportOptions;

    StreamTransportOptions: StreamTransportOptions;

declare const winston: winston.Transports;

  "description": "A logger for just about everything.",

  "author": "Charlie Robbins <charlie.robbins@gmail.com>",

    "David Hyde <dabh@alumni.stanford.edu>"

    "url": "https://github.com/winstonjs/winston.git"

    "@dabh/eslint-config-populist": "^5.0.0",

    "abstract-winston-transport": "^0.5.1",

    "lint": "eslint lib/*.js lib/winston/*.js lib/winston/**/*.js --resolve-plugins-relative-to ./node_modules/@dabh/eslint-config-populist",

    "test": "rimraf test/fixtures/logs/* && mocha",

    "test:coverage": "nyc npm run test:unit",

    "test:integration": "mocha test/integration",

    "build": "rimraf dist && babel lib -d dist",

		@@ -68,2 +68,3 @@ // Type definitions for winston 3.0
		replacer?: (key: string, value: any) => any;
		maximumDepth?: number;
		}
		@@ -75,2 +76,3 @@
		host: string;
		maximumDepth: number;
		port: number;
		@@ -77,0 +79,0 @@ auth?: { username?: string \| undefined, password?: string \| undefined, bearer?: string \| undefined };

		{
		"name": "winston",
		"description": "A logger for just about everything.",
		"version": "3.12.1",
		"version": "3.13.0",
		"author": "Charlie Robbins <charlie.robbins@gmail.com>",
		@@ -6,0 +6,0 @@ "maintainers": [

		@@ -31,3 +31,4 @@ /**
		var TransportStream = require('winston-transport');
		var jsonStringify = require('safe-stable-stringify');
		var _require2 = require('safe-stable-stringify'),
		configure = _require2.configure;

		@@ -59,2 +60,3 @@ /**
		_this.path = options.path \|\| '';
		_this.maximumDepth = options.maximumDepth;
		_this.agent = options.agent;
		@@ -281,2 +283,5 @@ _this.headers = options.headers \|\| {};
		});
		var jsonStringify = configure(_objectSpread({}, this.maximumDepth && {
		maximumDepth: this.maximumDepth
		}));
		req.end(Buffer.from(jsonStringify(options, this.options.replacer), 'utf8'));
		@@ -283,0 +288,0 @@ }

		@@ -14,3 +14,3 @@ /**
		const TransportStream = require('winston-transport');
		const jsonStringify = require('safe-stable-stringify');
		const { configure } = require('safe-stable-stringify');

		@@ -39,2 +39,3 @@ /**
		this.path = options.path \|\| '';
		this.maximumDepth = options.maximumDepth;
		this.agent = options.agent;
		@@ -258,4 +259,7 @@ this.headers = options.headers \|\| {};
		));
		const jsonStringify = configure({
		...(this.maximumDepth && { maximumDepth: this.maximumDepth })
		});
		req.end(Buffer.from(jsonStringify(options, this.options.replacer), 'utf8'));
		}
		};

Improved metrics