@lskjs/proxy/utils/createFeedback.js

"use strict";

var _interopRequireDefault = require("@babel/runtime/helpers/interopRequireDefault");

Object.defineProperty(exports, "__esModule", {
  value: true
});
exports["default"] = exports.createFeedback = void 0;

var _defineProperty2 = _interopRequireDefault(require("@babel/runtime/helpers/defineProperty"));

var _toConsumableArray2 = _interopRequireDefault(require("@babel/runtime/helpers/toConsumableArray"));

var _slicedToArray2 = _interopRequireDefault(require("@babel/runtime/helpers/slicedToArray"));

var _err = _interopRequireDefault(require("@lskjs/err"));

var _omitNull = _interopRequireDefault(require("@lskjs/utils/omitNull"));

var _getProxyLabels = require("./getProxyLabels");

function ownKeys(object, enumerableOnly) { var keys = Object.keys(object); if (Object.getOwnPropertySymbols) { var symbols = Object.getOwnPropertySymbols(object); if (enumerableOnly) { symbols = symbols.filter(function (sym) { return Object.getOwnPropertyDescriptor(object, sym).enumerable; }); } keys.push.apply(keys, symbols); } return keys; }

function _objectSpread(target) { for (var i = 1; i < arguments.length; i++) { var source = arguments[i] != null ? arguments[i] : {}; if (i % 2) { ownKeys(Object(source), true).forEach(function (key) { (0, _defineProperty2["default"])(target, key, source[key]); }); } else if (Object.getOwnPropertyDescriptors) { Object.defineProperties(target, Object.getOwnPropertyDescriptors(source)); } else { ownKeys(Object(source)).forEach(function (key) { Object.defineProperty(target, key, Object.getOwnPropertyDescriptor(source, key)); }); } } return target; }

// import { getErrCode } from './isNetworkError';
var getTimeout = function getTimeout(time) {
  return time ? "".concat(time, "ms") : '???ms';
};

var isLowerEqual = function isLowerEqual() {
  var str = arguments.length > 0 && arguments[0] !== undefined ? arguments[0] : '';
  var str2 = arguments.length > 1 && arguments[1] !== undefined ? arguments[1] : '';
  return str && str.toLowerCase() === str2;
};

var logKeys = function logKeys() {
  for (var _len = arguments.length, args = new Array(_len), _key = 0; _key < _len; _key++) {
    args[_key] = arguments[_key];
  }

  return args.map(function (_ref) {
    var _ref2 = (0, _slicedToArray2["default"])(_ref, 2),
        p1 = _ref2[0],
        p2 = _ref2[1];

    return p2 ? "[".concat(p1, "] ").concat(p2).trim() : null;
  }).filter(Boolean);
};

var createFeedback = function createFeedback() {
  var props = arguments.length > 0 && arguments[0] !== undefined ? arguments[0] : {};

  var _ref3 = arguments.length > 1 && arguments[1] !== undefined ? arguments[1] : {},
      log = _ref3.log,
      stats = _ref3.stats,
      tx = _ref3.tx,
      apm = _ref3.apm,
      labels = _ref3.labels;

  // console.log('[createFeedback]', { log: !!log, stats: !!stats, apm: !!apm });
  var _props$options = props.options,
      options = _props$options === void 0 ? {} : _props$options,
      proxy = props.proxy,
      tries = props.tries,
      maxTries = props.maxTries,
      _props$startedAt = props.startedAt,
      startedAt = _props$startedAt === void 0 ? Date.now() : _props$startedAt,
      _props$logPrefix = props.logPrefix,
      logPrefix = _props$logPrefix === void 0 ? [] : _props$logPrefix;
  var driver = options.driver,
      timeout = options.timeout,
      method = options.method,
      url = options.url;
  var prefix = [].concat((0, _toConsumableArray2["default"])(logPrefix), [['R', tries > 1 ? "".concat(tries, "/").concat(maxTries) : null], ['method', !isLowerEqual(method, 'get') ? method : null], ['url', url]]);
  var trace = [['driver', driver !== 'axios' ? driver : null], ['timeout', timeout]];
  var postfix = [['proxy', [proxy ? proxy.provider : null, proxy ? proxy.getUri() : 'localhost'].filter(Boolean).join(' ')]];
  if (!tx && apm) tx = apm.startTransaction('request');
  var customContext = {
    tries: tries,
    maxTries: maxTries,
    method: method,
    url: url
  };

  if (tx) {
    tx.setCustomContext(customContext);
    var proxyLabels = (0, _getProxyLabels.getProxyLabels)(proxy);
    tx.addLabels(_objectSpread(_objectSpread({}, labels || {}), proxyLabels));
  }

  if (log) log.trace.apply(log, (0, _toConsumableArray2["default"])(logKeys.apply(void 0, (0, _toConsumableArray2["default"])(prefix).concat(trace, postfix))));
  return {
    success: function success() {
      var _ref4 = arguments.length > 0 && arguments[0] !== undefined ? arguments[0] : {},
          size = _ref4.size;

      try {
        var time = Date.now() - startedAt;
        if (proxy && proxy.feedback) proxy.feedback({
          status: 'success',
          time: time,
          size: size
        });
        if (log) log.info.apply(log, ['[success]'].concat((0, _toConsumableArray2["default"])(logKeys.apply(void 0, (0, _toConsumableArray2["default"])(prefix).concat([['time', getTimeout(time)]], postfix)))));
        if (stats) stats.trigger({
          event: 'success',
          startedAt: startedAt
        });

        if (tx) {
          tx.addLabels((0, _omitNull["default"])({
            time: time,
            size: size
          }));
          tx.result = 'success';
          tx.end();
        }
      } catch (err) {
        // eslint-disable-next-line no-console
        console.log('[createFeedback] success.err ', err);
      }
    },
    error: function error(initErr) {
      var _ref5 = arguments.length > 1 && arguments[1] !== undefined ? arguments[1] : {},
          fatal = _ref5.fatal,
          size = _ref5.size;

      try {
        var time = Date.now() - startedAt;

        var errCode = _err["default"].getCode(initErr);

        var subcode = initErr === null || initErr === void 0 ? void 0 : initErr.subcode;

        var message = _err["default"].getMessage(initErr);

        if (proxy && proxy.feedback) {
          proxy.feedback({
            status: 'error',
            err: errCode,
            time: time,
            fatal: fatal,
            size: size
          });
        }

        if (log) log.error.apply(log, (0, _toConsumableArray2["default"])(logKeys.apply(void 0, (0, _toConsumableArray2["default"])(prefix).concat([['err', errCode], ['time', getTimeout(time)]], postfix))));
        if (stats) stats.trigger({
          event: 'error',
          startedAt: startedAt
        });
        if (apm) apm.captureError({
          code: errCode,
          subcode: subcode,
          message: message,
          data: initErr.data
        }); // TODO: подумать про await§

        if (tx) {
          tx.setCustomContext(_objectSpread(_objectSpread({}, customContext), {}, {
            errCode: errCode,
            errSubcode: subcode,
            errMessage: message
          }));
          tx.addLabels((0, _omitNull["default"])({
            time: time,
            size: size
          }));
          tx.result = errCode;
          tx.end();
        }
      } catch (err3) {
        // eslint-disable-next-line no-console
        console.log('[createFeedback] error.err ', err3);
      }
    }
  };
};

exports.createFeedback = createFeedback;
var _default = createFeedback;
exports["default"] = _default;
//# sourceMappingURL=createFeedback.js.map