@lskjs/server-api/lib/TestApi.js

"use strict";

var _interopRequireDefault = require("@babel/runtime/helpers/interopRequireDefault");
Object.defineProperty(exports, "__esModule", {
  value: true
});
exports["default"] = exports.collectConfigsLog = exports.collectConfigs = exports.TestApi = void 0;
var _regenerator = _interopRequireDefault(require("@babel/runtime/regenerator"));
var _defineProperty2 = _interopRequireDefault(require("@babel/runtime/helpers/defineProperty"));
var _classCallCheck2 = _interopRequireDefault(require("@babel/runtime/helpers/classCallCheck"));
var _createClass2 = _interopRequireDefault(require("@babel/runtime/helpers/createClass"));
var _get2 = _interopRequireDefault(require("@babel/runtime/helpers/get"));
var _inherits2 = _interopRequireDefault(require("@babel/runtime/helpers/inherits"));
var _possibleConstructorReturn2 = _interopRequireDefault(require("@babel/runtime/helpers/possibleConstructorReturn"));
var _getPrototypeOf2 = _interopRequireDefault(require("@babel/runtime/helpers/getPrototypeOf"));
var _asyncToGenerator2 = _interopRequireDefault(require("@babel/runtime/helpers/asyncToGenerator"));
var _err = _interopRequireDefault(require("@lskjs/err"));
var _asyncMapValues = _interopRequireDefault(require("@lskjs/utils/asyncMapValues"));
var _bluebird = _interopRequireDefault(require("bluebird"));
var _Api2 = _interopRequireDefault(require("./Api"));
function ownKeys(object, enumerableOnly) { var keys = Object.keys(object); if (Object.getOwnPropertySymbols) { var symbols = Object.getOwnPropertySymbols(object); 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 = null != arguments[i] ? arguments[i] : {}; i % 2 ? ownKeys(Object(source), !0).forEach(function (key) { (0, _defineProperty2["default"])(target, key, source[key]); }) : Object.getOwnPropertyDescriptors ? Object.defineProperties(target, Object.getOwnPropertyDescriptors(source)) : ownKeys(Object(source)).forEach(function (key) { Object.defineProperty(target, key, Object.getOwnPropertyDescriptor(source, key)); }); } return target; }
function _createSuper(Derived) { var hasNativeReflectConstruct = _isNativeReflectConstruct(); return function _createSuperInternal() { var Super = (0, _getPrototypeOf2["default"])(Derived), result; if (hasNativeReflectConstruct) { var NewTarget = (0, _getPrototypeOf2["default"])(this).constructor; result = Reflect.construct(Super, arguments, NewTarget); } else { result = Super.apply(this, arguments); } return (0, _possibleConstructorReturn2["default"])(this, result); }; }
function _isNativeReflectConstruct() { if (typeof Reflect === "undefined" || !Reflect.construct) return false; if (Reflect.construct.sham) return false; if (typeof Proxy === "function") return true; try { Boolean.prototype.valueOf.call(Reflect.construct(Boolean, [], function () {})); return true; } catch (e) { return false; } } /* eslint-disable global-require */ // import collectConfigs from '@lskjs/module/utils/collectConfigs';
var collectConfigs = /*#__PURE__*/function () {
  var _ref = (0, _asyncToGenerator2["default"])( /*#__PURE__*/_regenerator["default"].mark(function _callee2(m) {
    return _regenerator["default"].wrap(function _callee2$(_context2) {
      while (1) switch (_context2.prev = _context2.next) {
        case 0:
          _context2.t0 = m.config;
          _context2.next = 3;
          return (0, _asyncMapValues["default"])(m.__availableModules, /*#__PURE__*/function () {
            var _ref2 = (0, _asyncToGenerator2["default"])( /*#__PURE__*/_regenerator["default"].mark(function _callee(_, name) {
              return _regenerator["default"].wrap(function _callee$(_context) {
                while (1) switch (_context.prev = _context.next) {
                  case 0:
                    _context.t0 = collectConfigs;
                    _context.next = 3;
                    return m.module(name);
                  case 3:
                    _context.t1 = _context.sent;
                    return _context.abrupt("return", (0, _context.t0)(_context.t1));
                  case 5:
                  case "end":
                    return _context.stop();
                }
              }, _callee);
            }));
            return function (_x2, _x3) {
              return _ref2.apply(this, arguments);
            };
          }());
        case 3:
          _context2.t1 = _context2.sent;
          return _context2.abrupt("return", {
            config: _context2.t0,
            modules: _context2.t1
          });
        case 5:
        case "end":
          return _context2.stop();
      }
    }, _callee2);
  }));
  return function collectConfigs(_x) {
    return _ref.apply(this, arguments);
  };
}();
exports.collectConfigs = collectConfigs;
var collectConfigsLog = /*#__PURE__*/function () {
  var _ref3 = (0, _asyncToGenerator2["default"])( /*#__PURE__*/_regenerator["default"].mark(function _callee4(m) {
    return _regenerator["default"].wrap(function _callee4$(_context4) {
      while (1) switch (_context4.prev = _context4.next) {
        case 0:
          _context4.t0 = m.config.debug;
          _context4.t1 = m.config.log;
          _context4.next = 4;
          return (0, _asyncMapValues["default"])(m.__availableModules, /*#__PURE__*/function () {
            var _ref4 = (0, _asyncToGenerator2["default"])( /*#__PURE__*/_regenerator["default"].mark(function _callee3(_, name) {
              return _regenerator["default"].wrap(function _callee3$(_context3) {
                while (1) switch (_context3.prev = _context3.next) {
                  case 0:
                    _context3.t0 = collectConfigsLog;
                    _context3.next = 3;
                    return m.module(name);
                  case 3:
                    _context3.t1 = _context3.sent;
                    return _context3.abrupt("return", (0, _context3.t0)(_context3.t1));
                  case 5:
                  case "end":
                    return _context3.stop();
                }
              }, _callee3);
            }));
            return function (_x5, _x6) {
              return _ref4.apply(this, arguments);
            };
          }());
        case 4:
          _context4.t2 = _context4.sent;
          return _context4.abrupt("return", {
            debug: _context4.t0,
            log: _context4.t1,
            modules: _context4.t2
          });
        case 6:
        case "end":
          return _context4.stop();
      }
    }, _callee4);
  }));
  return function collectConfigsLog(_x4) {
    return _ref3.apply(this, arguments);
  };
}();
exports.collectConfigsLog = collectConfigsLog;
var middleware = function middleware(req, res, next) {
  req.file = '[some-file]';
  if (Math.random() < 0.5) {
    console.log('test.error');
    next(new Error('test.error'));
  } else {
    next();
  }
};
var TestApi = /*#__PURE__*/function (_Api) {
  (0, _inherits2["default"])(TestApi, _Api);
  var _super = _createSuper(TestApi);
  function TestApi() {
    (0, _classCallCheck2["default"])(this, TestApi);
    return _super.apply(this, arguments);
  }
  (0, _createClass2["default"])(TestApi, [{
    key: "getRoutes",
    value: function getRoutes() {
      var _this = this;
      return _objectSpread(_objectSpread({}, (0, _get2["default"])((0, _getPrototypeOf2["default"])(TestApi.prototype), "getRoutes", this).call(this)), {}, {
        '/middleware/1': function () {
          var _middleware = (0, _asyncToGenerator2["default"])( /*#__PURE__*/_regenerator["default"].mark(function _callee5(req, res) {
            return _regenerator["default"].wrap(function _callee5$(_context5) {
              while (1) switch (_context5.prev = _context5.next) {
                case 0:
                  _context5.next = 2;
                  return _this.useMiddleware(middleware, req, res);
                case 2:
                  console.log('req.file', req.file);
                  return _context5.abrupt("return", {
                    file: req.file
                  });
                case 4:
                case "end":
                  return _context5.stop();
              }
            }, _callee5);
          }));
          function middleware1(_x7, _x8) {
            return _middleware.apply(this, arguments);
          }
          return middleware1;
        }(),
        '/middleware/2': [middleware, /*#__PURE__*/function () {
          var _ref5 = (0, _asyncToGenerator2["default"])( /*#__PURE__*/_regenerator["default"].mark(function _callee6(req, res) {
            return _regenerator["default"].wrap(function _callee6$(_context6) {
              while (1) switch (_context6.prev = _context6.next) {
                case 0:
                  console.log('req.file', req.file);
                  return _context6.abrupt("return", {
                    file: req.file
                  });
                case 2:
                case "end":
                  return _context6.stop();
              }
            }, _callee6);
          }));
          return function (_x9, _x10) {
            return _ref5.apply(this, arguments);
          };
        }()],
        '/res/1': function res1() {
          return 123;
        },
        '/res/2': function res2() {
          return 'Hello';
        },
        '/res/3': function res3(req, res) {
          return res.send('Hello');
        },
        '/res/4': function res4() {
          return {
            test: 123
          };
        },
        '/res/5': function res5() {
          return [1, 2, 3, 4];
        },
        '/res/6': function res6() {
          return true;
        },
        '/res/7': function res7() {
          return null;
        },
        '/res/8': function res8() {
          return undefined;
        },
        '/res/9': function res9() {
          return function () {};
        },
        '/res/10': function res10() {
          return /[0-9]ig/;
        },
        '/res/11': function res11() {
          return {
            __raw: '<html />'
          };
        },
        '/res/12': function res12() {
          return {
            __pack: true,
            some: 123,
            help: 'me'
          };
        },
        '/res/13': function res13() {
          return function some() {
            var secret = 123;
            return secret;
          };
        },
        '/async/ok': function () {
          var _asyncOk = (0, _asyncToGenerator2["default"])( /*#__PURE__*/_regenerator["default"].mark(function _callee7() {
            var delay;
            return _regenerator["default"].wrap(function _callee7$(_context7) {
              while (1) switch (_context7.prev = _context7.next) {
                case 0:
                  delay = 5000;
                  _context7.next = 3;
                  return _bluebird["default"].delay(delay);
                case 3:
                  return _context7.abrupt("return", {
                    delay: delay
                  });
                case 4:
                case "end":
                  return _context7.stop();
              }
            }, _callee7);
          }));
          function asyncOk() {
            return _asyncOk.apply(this, arguments);
          }
          return asyncOk;
        }(),
        '/async/err': function () {
          var _asyncErr = (0, _asyncToGenerator2["default"])( /*#__PURE__*/_regenerator["default"].mark(function _callee8() {
            var delay;
            return _regenerator["default"].wrap(function _callee8$(_context8) {
              while (1) switch (_context8.prev = _context8.next) {
                case 0:
                  delay = 5000;
                  _context8.next = 3;
                  return _bluebird["default"].delay(delay);
                case 3:
                  throw new _err["default"]('ERR_QWE', {
                    delay: delay
                  });
                case 4:
                case "end":
                  return _context8.stop();
              }
            }, _callee8);
          }));
          function asyncErr() {
            return _asyncErr.apply(this, arguments);
          }
          return asyncErr;
        }(),
        '/async/404': function () {
          var _async = (0, _asyncToGenerator2["default"])( /*#__PURE__*/_regenerator["default"].mark(function _callee9() {
            var delay;
            return _regenerator["default"].wrap(function _callee9$(_context9) {
              while (1) switch (_context9.prev = _context9.next) {
                case 0:
                  delay = 5000;
                  _context9.next = 3;
                  return _bluebird["default"].delay(delay);
                case 3:
                  throw new _err["default"]('ERR_QWE', {
                    delay: delay,
                    status: 404
                  });
                case 4:
                case "end":
                  return _context9.stop();
              }
            }, _callee9);
          }));
          function async404() {
            return _async.apply(this, arguments);
          }
          return async404;
        }(),
        '/async/502': function () {
          var _async2 = (0, _asyncToGenerator2["default"])( /*#__PURE__*/_regenerator["default"].mark(function _callee10() {
            var delay;
            return _regenerator["default"].wrap(function _callee10$(_context10) {
              while (1) switch (_context10.prev = _context10.next) {
                case 0:
                  delay = 5000;
                  _context10.next = 3;
                  return _bluebird["default"].delay(delay);
                case 3:
                  throw new _err["default"]('ERR_QWE', {
                    delay: delay,
                    status: 502
                  });
                case 4:
                case "end":
                  return _context10.stop();
              }
            }, _callee10);
          }));
          function async502() {
            return _async2.apply(this, arguments);
          }
          return async502;
        }(),
        '/err/1': function err1() {
          throw new _err["default"]('TEST_ERROR_CODE');
        },
        '/err/2': function err2() {
          throw {
            code: 'TEST_ERROR_CODE',
            message: 'The message text'
          };
        },
        '/err/3': function err3() {
          throw new Error('The message text');
        },
        '/err/4': function err4() {
          throw new Error('TEST_ERROR_CODE');
        },
        '/err/5': function err5() {
          var error = new Error('The message text');
          error.code = 'TEST_ERROR_CODE';
          throw new Error('The message text');
        },
        '/err/6': function err6() {
          throw {};
        },
        '/err/7': function err7() {
          throw null;
        },
        '/err/10': function err10() {
          throw new _err["default"]();
        },
        '/err/11': function err11() {
          throw new _err["default"]('TEST_ERROR_CODE');
        },
        '/err/12': function err12() {
          throw new _err["default"]('TEST_ERROR_CODE', {
            message: 'The message text'
          });
        },
        '/err/13': function err13() {
          throw new _err["default"]('TEST_ERROR_CODE', {
            message: 'The message text'
          }, {
            status: 404
          });
        },
        '/err/14': function err14() {
          throw new _err["default"]({
            code: 'TEST_ERROR_CODE',
            message: 'The message text'
          }, {
            status: 404
          });
        },
        '/err/15': function err15() {
          throw new _err["default"]('test.someError', {
            status: 404
          });
        },
        '/err/16': function err16() {
          throw new _err["default"]('test.anotherError', {
            status: 404,
            data: {
              hello: 'world'
            }
          });
        },
        '/err/17': function err17() {
          throw new Error('err', 'file', 123);
        },
        '/err/18': function err18() {
          throw new _err["default"]({
            code: 'TEST_ERROR_CODE',
            message: 'The message text'
          }, {
            status: 404
          });
        },
        '/err/19': function err19() {
          throw new _err["default"]({
            code: 'TEST_ERROR_CODE',
            message: 'The message text'
          }, {
            status: 404
          });
        },
        '/err/20': function err20() {
          throw new _err["default"]({
            code: 'TEST_ERROR_CODE',
            message: 'The message text'
          }, {
            status: 404
          });
        },
        '/err/21': function err21() {
          throw new _err["default"]('user.notFound', {
            status: 404
          });
        },
        '/err/22': function err22() {
          throw new _err["default"]('some.error', {
            status: 404
          });
        },
        '/err/24': function err24() {
          throw new _err["default"]('some.error', {
            status: 404
          });
        },
        '/form': function form(req) {
          var _req$data = req.data,
            email = _req$data.email,
            password = _req$data.password;
          if (password !== 'password') throw new _err["default"]('auth.passwordInvalud', {
            status: 400,
            data: {
              password: password
            }
          });
          if (email !== 'test@coder24.ru') throw new _err["default"]('auth.emailInvalud', {
            status: 400,
            data: {
              email: email
            }
          });
          return {
            ok: 123
          };
        },
        '/locale': function locale(req) {
          _this.log.trace('locale start');
          // console.log('getLocale', req.getLocale);
          return {
            locale: req.getLocale(),
            test: req.t('test.hello')
          };
        },
        '/app/config': function appConfig() {
          return collectConfigs(_this.app);
        },
        '/app/config/log': function appConfigLog() {
          return collectConfigsLog(_this.app);
        },
        '/req/auth': function () {
          var _reqAuth = (0, _asyncToGenerator2["default"])( /*#__PURE__*/_regenerator["default"].mark(function _callee11(req) {
            return _regenerator["default"].wrap(function _callee11$(_context11) {
              while (1) switch (_context11.prev = _context11.next) {
                case 0:
                  return _context11.abrupt("return", req.user);
                case 1:
                case "end":
                  return _context11.stop();
              }
            }, _callee11);
          }));
          function reqAuth(_x11) {
            return _reqAuth.apply(this, arguments);
          }
          return reqAuth;
        }(),
        '/req/user': function () {
          var _reqUser = (0, _asyncToGenerator2["default"])( /*#__PURE__*/_regenerator["default"].mark(function _callee12(req) {
            return _regenerator["default"].wrap(function _callee12$(_context12) {
              while (1) switch (_context12.prev = _context12.next) {
                case 0:
                  return _context12.abrupt("return", req.user);
                case 1:
                case "end":
                  return _context12.stop();
              }
            }, _callee12);
          }));
          function reqUser(_x12) {
            return _reqUser.apply(this, arguments);
          }
          return reqUser;
        }(),
        '/req/userId': function () {
          var _reqUserId = (0, _asyncToGenerator2["default"])( /*#__PURE__*/_regenerator["default"].mark(function _callee13(req) {
            return _regenerator["default"].wrap(function _callee13$(_context13) {
              while (1) switch (_context13.prev = _context13.next) {
                case 0:
                  return _context13.abrupt("return", req.userId || req.user && req.user_id);
                case 1:
                case "end":
                  return _context13.stop();
              }
            }, _callee13);
          }));
          function reqUserId(_x13) {
            return _reqUserId.apply(this, arguments);
          }
          return reqUserId;
        }(),
        '/req/:log?': this.req.bind(this),
        '/user/one': function () {
          var _userOne = (0, _asyncToGenerator2["default"])( /*#__PURE__*/_regenerator["default"].mark(function _callee14() {
            var UserModel, user;
            return _regenerator["default"].wrap(function _callee14$(_context14) {
              while (1) switch (_context14.prev = _context14.next) {
                case 0:
                  UserModel = _this.app.UserModel;
                  _context14.next = 3;
                  return UserModel.findOne();
                case 3:
                  user = _context14.sent;
                  return _context14.abrupt("return", user);
                case 5:
                case "end":
                  return _context14.stop();
              }
            }, _callee14);
          }));
          function userOne() {
            return _userOne.apply(this, arguments);
          }
          return userOne;
        }(),
        '/path/*': function path() {
          return {
            path: _this.path,
            paths: _this.paths
          };
        }
      });
    }
  }, {
    key: "req",
    value: function req(_req) {
      var res = {
        params: _req.params,
        query: _req.query,
        headers: _req.headers
      };
      if (_req.params.log) {
        this.log.info('req', res);
        res.body = _req.body;
        this.log.info('body', _req.body);
      }
      return res;
    }
  }]);
  return TestApi;
}(_Api2["default"]);
exports.TestApi = TestApi;
var _default = TestApi;
exports["default"] = _default;
//# sourceMappingURL=TestApi.js.map