@lskjs/server-api/utils/awaitHealthcheck.js

"use strict";

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

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

var _regenerator = _interopRequireDefault(require("@babel/runtime/regenerator"));

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

var _env = _interopRequireDefault(require("@lskjs/env"));

var _bluebird = _interopRequireDefault(require("bluebird"));

var _isFunction = _interopRequireDefault(require("lodash/isFunction"));

var _mapValues = _interopRequireDefault(require("lodash/mapValues"));

var _pick = _interopRequireDefault(require("lodash/pick"));

// import some from 'lodash/some';
var _default = /*#__PURE__*/function () {
  var _ref = (0, _asyncToGenerator2["default"])( /*#__PURE__*/_regenerator["default"].mark(function _callee2(healthchecks) {
    var data, status, promises;
    return _regenerator["default"].wrap(function _callee2$(_context2) {
      while (1) {
        switch (_context2.prev = _context2.next) {
          case 0:
            data = {}; // eslint-disable-next-line no-param-reassign

            _context2.next = 3;
            return healthchecks;

          case 3:
            healthchecks = _context2.sent;
            // eslint-disable-next-line no-param-reassign
            if (!healthchecks) healthchecks = {
              healthcheck: healthchecks
            };
            status = 200;
            promises = (0, _mapValues["default"])(healthchecks, /*#__PURE__*/function () {
              var _ref2 = (0, _asyncToGenerator2["default"])( /*#__PURE__*/_regenerator["default"].mark(function _callee(fn, key) {
                var start, res;
                return _regenerator["default"].wrap(function _callee$(_context) {
                  while (1) {
                    switch (_context.prev = _context.next) {
                      case 0:
                        if ((0, _isFunction["default"])(fn)) {
                          _context.next = 2;
                          break;
                        }

                        return _context.abrupt("return", fn);

                      case 2:
                        start = Date.now();
                        _context.prev = 3;
                        _context.next = 6;
                        return fn();

                      case 6:
                        res = _context.sent;
                        return _context.abrupt("return", {
                          res: res,
                          timeout: Date.now() - start
                        });

                      case 10:
                        _context.prev = 10;
                        _context.t0 = _context["catch"](3);
                        status = 500;
                        console.error("healthchecks[".concat(key, "] err"), _context.t0); //eslint-disable-line

                        return _context.abrupt("return", {
                          res: null,
                          err: _context.t0,
                          timeout: Date.now() - start
                        });

                      case 15:
                      case "end":
                        return _context.stop();
                    }
                  }
                }, _callee, null, [[3, 10]]);
              }));

              return function (_x2, _x3) {
                return _ref2.apply(this, arguments);
              };
            }());
            _context2.next = 9;
            return _bluebird["default"].props(promises);

          case 9:
            data = _context2.sent;
            return _context2.abrupt("return", {
              __pack: true,
              __status: status,
              ok: true,
              date: new Date(),
              env: _env["default"],
              debug: (0, _pick["default"])(process.env, ['CI_PIPELINE_ID', 'CI_JOB_ID']),
              data: data
            });

          case 11:
          case "end":
            return _context2.stop();
        }
      }
    }, _callee2);
  }));

  return function (_x) {
    return _ref.apply(this, arguments);
  };
}();

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