@lskjs/auth/AuthClientModule.js

"use strict";

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

var _typeof = require("@babel/runtime/helpers/typeof");

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

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

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

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

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

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

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

var _get3 = _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 _env = require("@lskjs/env");

var _module = _interopRequireDefault(require("@lskjs/module"));

var _jsCookie = _interopRequireDefault(require("js-cookie"));

var _get4 = _interopRequireDefault(require("lodash/get"));

var _LocalStorage = _interopRequireDefault(require("./Storage/LocalStorage"));

var _MemoryStorage = _interopRequireDefault(require("./Storage/MemoryStorage"));

var _stores = _interopRequireDefault(require("./stores"));

var _excluded = ["name"];

function _getRequireWildcardCache(nodeInterop) { if (typeof WeakMap !== "function") return null; var cacheBabelInterop = new WeakMap(); var cacheNodeInterop = new WeakMap(); return (_getRequireWildcardCache = function _getRequireWildcardCache(nodeInterop) { return nodeInterop ? cacheNodeInterop : cacheBabelInterop; })(nodeInterop); }

function _interopRequireWildcard(obj, nodeInterop) { if (!nodeInterop && obj && obj.__esModule) { return obj; } if (obj === null || _typeof(obj) !== "object" && typeof obj !== "function") { return { "default": obj }; } var cache = _getRequireWildcardCache(nodeInterop); if (cache && cache.has(obj)) { return cache.get(obj); } var newObj = {}; var hasPropertyDescriptor = Object.defineProperty && Object.getOwnPropertyDescriptor; for (var key in obj) { if (key !== "default" && Object.prototype.hasOwnProperty.call(obj, key)) { var desc = hasPropertyDescriptor ? Object.getOwnPropertyDescriptor(obj, key) : null; if (desc && (desc.get || desc.set)) { Object.defineProperty(newObj, key, desc); } else { newObj[key] = obj[key]; } } } newObj["default"] = obj; if (cache) { cache.set(obj, newObj); } return newObj; }

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; }

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; } }

// const DEBUG = __DEV__ && __STAGE__ === 'isuvorov';
// const DEBUG = false;
var AuthClientModule = /*#__PURE__*/function (_Module) {
  (0, _inherits2["default"])(AuthClientModule, _Module);

  var _super = _createSuper(AuthClientModule);

  function AuthClientModule() {
    var _this;

    (0, _classCallCheck2["default"])(this, AuthClientModule);

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

    _this = _super.call.apply(_super, [this].concat(args));
    _this.storages = {
      MemoryStorage: _MemoryStorage["default"],
      LocalStorage: _LocalStorage["default"]
    };
    return _this;
  }

  (0, _createClass2["default"])(AuthClientModule, [{
    key: "init",
    value: function () {
      var _init = (0, _asyncToGenerator2["default"])( /*#__PURE__*/_regenerator["default"].mark(function _callee() {
        var _this$storages, _this$storages2;

        var AuthStore;
        return _regenerator["default"].wrap(function _callee$(_context) {
          while (1) {
            switch (_context.prev = _context.next) {
              case 0:
                _context.next = 2;
                return (0, _get3["default"])((0, _getPrototypeOf2["default"])(AuthClientModule.prototype), "init", this).call(this);

              case 2:
                _context.next = 4;
                return this.module('stores.AuthStore');

              case 4:
                AuthStore = _context.sent;
                this.store = new AuthStore();

                if (!(_env.isClient && (_this$storages = this.storages) !== null && _this$storages !== void 0 && _this$storages.LocalStorage)) {
                  _context.next = 10;
                  break;
                }

                this.localStorage = new this.storages.LocalStorage({
                  // memoryState: this.app.rootState,
                  config: (0, _get4["default"])(this, 'app.config.storage', {})
                });
                _context.next = 10;
                return this.localStorage.init();

              case 10:
                if (!((_this$storages2 = this.storages) !== null && _this$storages2 !== void 0 && _this$storages2.MemoryStorage)) {
                  _context.next = 14;
                  break;
                }

                this.memoryStorage = new this.storages.MemoryStorage({
                  state: this.app.rootState,
                  config: (0, _get4["default"])(this, 'app.config.storage', {})
                });
                _context.next = 14;
                return this.memoryStorage.init();

              case 14:
              case "end":
                return _context.stop();
            }
          }
        }, _callee, this);
      }));

      function init() {
        return _init.apply(this, arguments);
      }

      return init;
    }()
  }, {
    key: "getModules",
    value: function () {
      var _getModules = (0, _asyncToGenerator2["default"])( /*#__PURE__*/_regenerator["default"].mark(function _callee2() {
        return _regenerator["default"].wrap(function _callee2$(_context2) {
          while (1) {
            switch (_context2.prev = _context2.next) {
              case 0:
                _context2.t0 = _objectSpread;
                _context2.t1 = _objectSpread;
                _context2.t2 = {};
                _context2.next = 5;
                return (0, _get3["default"])((0, _getPrototypeOf2["default"])(AuthClientModule.prototype), "getModules", this).call(this);

              case 5:
                _context2.t3 = _context2.sent;
                _context2.t4 = (0, _context2.t1)(_context2.t2, _context2.t3);
                _context2.t5 = {};
                _context2.t6 = {
                  stores: [function () {
                    return Promise.resolve().then(function () {
                      return _interopRequireWildcard(require('@lskjs/mobx/mobxStores'));
                    });
                  }, {
                    stores: _stores["default"]
                  }]
                };
                return _context2.abrupt("return", (0, _context2.t0)(_context2.t4, _context2.t5, _context2.t6));

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

      function getModules() {
        return _getModules.apply(this, arguments);
      }

      return getModules;
    }()
  }, {
    key: "run",
    value: function () {
      var _run = (0, _asyncToGenerator2["default"])( /*#__PURE__*/_regenerator["default"].mark(function _callee3() {
        var _this2 = this;

        return _regenerator["default"].wrap(function _callee3$(_context3) {
          while (1) {
            switch (_context3.prev = _context3.next) {
              case 0:
                _context3.next = 2;
                return (0, _get3["default"])((0, _getPrototypeOf2["default"])(AuthClientModule.prototype), "run", this).call(this);

              case 2:
                _context3.next = 4;
                return this.loadStore();

              case 4:
                if (_env.isClient && this.store.isAuth()) {
                  setTimeout(function () {
                    _this2.updateSession();
                  }, _env.isDev ? 10000 : 1000);
                }

              case 5:
              case "end":
                return _context3.stop();
            }
          }
        }, _callee3, this);
      }));

      function run() {
        return _run.apply(this, arguments);
      }

      return run;
    }()
  }, {
    key: "setToken",
    value: function () {
      var _setToken = (0, _asyncToGenerator2["default"])( /*#__PURE__*/_regenerator["default"].mark(function _callee4(token) {
        var expires,
            cookies,
            api,
            _get2,
            _get2$name,
            name,
            options,
            _args4 = arguments;

        return _regenerator["default"].wrap(function _callee4$(_context4) {
          while (1) {
            switch (_context4.prev = _context4.next) {
              case 0:
                expires = _args4.length > 1 && _args4[1] !== undefined ? _args4[1] : 365;
                cookies = _args4.length > 2 && _args4[2] !== undefined ? _args4[2] : true;
                if (this.debug) this.log.trace('AuthClientModule.setToken', token);

                if (!this.app.hasModule('api')) {
                  _context4.next = 9;
                  break;
                }

                _context4.next = 6;
                return this.app.module('api');

              case 6:
                api = _context4.sent;
                _context4.next = 9;
                return api.setToken(token);

              case 9:
                if (this.app.api) this.app.api.setAuthToken(token);
                if (this.app.apiq) this.app.apiq.setToken(token);
                if (this.memoryStorage) this.memoryStorage.set('req.token', token);
                _get2 = (0, _get4["default"])(this.app, 'config.jwt.cookie', {}), _get2$name = _get2.name, name = _get2$name === void 0 ? 'token' : _get2$name, options = (0, _objectWithoutProperties2["default"])(_get2, _excluded);
                if (this.debug) this.log.trace('AuthClientModule.setToken cookie', {
                  name: name,
                  options: options,
                  token: token
                }, _env.isClient && cookies, _env.isClient, cookies);

                if (_env.isClient && cookies) {
                  if (token == null) {
                    if (this.debug) this.log.trace('cookie.remove(name, options)', name, options);

                    _jsCookie["default"].remove(name, options);
                  } else {
                    if (this.debug) this.log.trace('cookie.set(name, token, { expires, ...options })', name, token, _objectSpread({
                      expires: expires
                    }, options));

                    _jsCookie["default"].set(name, token, _objectSpread({
                      expires: expires
                    }, options));
                  }
                }

              case 15:
              case "end":
                return _context4.stop();
            }
          }
        }, _callee4, this);
      }));

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

      return setToken;
    }()
  }, {
    key: "loadStore",
    value: function () {
      var _loadStore = (0, _asyncToGenerator2["default"])( /*#__PURE__*/_regenerator["default"].mark(function _callee5() {
        var state, _session2, _yield$this$store$con, _session, session;

        return _regenerator["default"].wrap(function _callee5$(_context5) {
          while (1) {
            switch (_context5.prev = _context5.next) {
              case 0:
                state = {};

                if (this.memoryStorage) {
                  state = _objectSpread(_objectSpread({}, state), this.memoryStorage.get('auth'));
                }

                if (this.localStorage) {
                  state = _objectSpread(_objectSpread({}, state), this.localStorage.get('auth'));
                }

                if (!(!state.session && this.memoryStorage.get('req.user'))) {
                  _context5.next = 18;
                  break;
                }

                _session2 = {
                  _id: this.memoryStorage.get('req.user._id'),
                  user: this.memoryStorage.get('req.user'),
                  token: this.memoryStorage.get('req.token')
                };
                state = _objectSpread(_objectSpread({}, state), {}, {
                  session: _session2,
                  sessions: [_session2]
                });

                if (!_env.isServer) {
                  _context5.next = 18;
                  break;
                }

                _context5.prev = 7;
                _context5.next = 10;
                return this.store.constructor.api.session({
                  __init: true,
                  session: _session2
                });

              case 10:
                _yield$this$store$con = _context5.sent;
                _session = _yield$this$store$con.data;

                if (_session && Object.keys(_session).length > 0 && _session2._id === _session._id) {
                  state.session = _session;
                  state.sessions = [_session];
                }

                _context5.next = 18;
                break;

              case 15:
                _context5.prev = 15;
                _context5.t0 = _context5["catch"](7);
                this.log.error('loadStore session', _context5.t0);

              case 18:
                if (this.debug) this.log.trace('loadStore', state);
                this.store.setState(state);
                session = this.store.session;
                _context5.next = 23;
                return this.setToken(session ? session.token : null);

              case 23:
              case "end":
                return _context5.stop();
            }
          }
        }, _callee5, this, [[7, 15]]);
      }));

      function loadStore() {
        return _loadStore.apply(this, arguments);
      }

      return loadStore;
    }()
  }, {
    key: "saveStore",
    value: function () {
      var _saveStore = (0, _asyncToGenerator2["default"])( /*#__PURE__*/_regenerator["default"].mark(function _callee6() {
        var state, token;
        return _regenerator["default"].wrap(function _callee6$(_context6) {
          while (1) {
            switch (_context6.prev = _context6.next) {
              case 0:
                state = this.store.getState();
                if (this.debug) this.log.trace('saveStore', state);
                if (this.localStorage) this.localStorage.set('auth', state);
                if (this.memoryStorage) this.memoryStorage.set('auth', state);
                token = state.session ? state.session.token : null;
                _context6.next = 7;
                return this.setToken(token);

              case 7:
              case "end":
                return _context6.stop();
            }
          }
        }, _callee6, this);
      }));

      function saveStore() {
        return _saveStore.apply(this, arguments);
      }

      return saveStore;
    }()
  }, {
    key: "isAuth",
    value: function isAuth() {
      return this.store.isAuth();
    }
  }, {
    key: "getSession",
    value: function getSession() {
      return this.store.getSession();
    }
  }, {
    key: "getUserId",
    value: function getUserId() {
      return this.store.getUserId();
    }
  }, {
    key: "logout",
    value: function () {
      var _logout = (0, _asyncToGenerator2["default"])( /*#__PURE__*/_regenerator["default"].mark(function _callee7() {
        var redirect,
            _args7 = arguments;
        return _regenerator["default"].wrap(function _callee7$(_context7) {
          while (1) {
            switch (_context7.prev = _context7.next) {
              case 0:
                redirect = _args7.length > 0 && _args7[0] !== undefined ? _args7[0] : true;
                _context7.next = 3;
                return this.store.logout();

              case 3:
                _context7.next = 5;
                return this.saveStore();

              case 5:
                if (redirect) this.app.redirect('/');

              case 6:
              case "end":
                return _context7.stop();
            }
          }
        }, _callee7, this);
      }));

      function logout() {
        return _logout.apply(this, arguments);
      }

      return logout;
    }()
  }, {
    key: "signup",
    value: function () {
      var _signup = (0, _asyncToGenerator2["default"])( /*#__PURE__*/_regenerator["default"].mark(function _callee8() {
        var _this$store;

        var res,
            _args8 = arguments;
        return _regenerator["default"].wrap(function _callee8$(_context8) {
          while (1) {
            switch (_context8.prev = _context8.next) {
              case 0:
                _context8.next = 2;
                return (_this$store = this.store).signup.apply(_this$store, _args8);

              case 2:
                res = _context8.sent;
                _context8.next = 5;
                return this.saveStore();

              case 5:
                return _context8.abrupt("return", res);

              case 6:
              case "end":
                return _context8.stop();
            }
          }
        }, _callee8, this);
      }));

      function signup() {
        return _signup.apply(this, arguments);
      }

      return signup;
    }()
  }, {
    key: "login",
    value: function () {
      var _login = (0, _asyncToGenerator2["default"])( /*#__PURE__*/_regenerator["default"].mark(function _callee9() {
        var _this$log, _this$store2;

        var _len2,
            args,
            _key2,
            res,
            _args9 = arguments;

        return _regenerator["default"].wrap(function _callee9$(_context9) {
          while (1) {
            switch (_context9.prev = _context9.next) {
              case 0:
                for (_len2 = _args9.length, args = new Array(_len2), _key2 = 0; _key2 < _len2; _key2++) {
                  args[_key2] = _args9[_key2];
                }

                (_this$log = this.log).debug.apply(_this$log, ['login'].concat(args));

                _context9.next = 4;
                return (_this$store2 = this.store).login.apply(_this$store2, args);

              case 4:
                res = _context9.sent;
                this.log.trace('login res', res);
                _context9.next = 8;
                return this.saveStore();

              case 8:
                return _context9.abrupt("return", res);

              case 9:
              case "end":
                return _context9.stop();
            }
          }
        }, _callee9, this);
      }));

      function login() {
        return _login.apply(this, arguments);
      }

      return login;
    }()
  }, {
    key: "updateSession",
    value: function () {
      var _updateSession = (0, _asyncToGenerator2["default"])( /*#__PURE__*/_regenerator["default"].mark(function _callee10() {
        var _this$store3,
            res,
            _args10 = arguments;

        return _regenerator["default"].wrap(function _callee10$(_context10) {
          while (1) {
            switch (_context10.prev = _context10.next) {
              case 0:
                _context10.prev = 0;
                _context10.next = 3;
                return (_this$store3 = this.store).updateSession.apply(_this$store3, _args10);

              case 3:
                res = _context10.sent;
                _context10.next = 6;
                return this.saveStore();

              case 6:
                return _context10.abrupt("return", res);

              case 9:
                _context10.prev = 9;
                _context10.t0 = _context10["catch"](0);

                if (!(_context10.t0.code === 'auth.userNotFound')) {
                  _context10.next = 14;
                  break;
                }

                _context10.next = 14;
                return this.logout();

              case 14:
                throw _context10.t0;

              case 15:
              case "end":
                return _context10.stop();
            }
          }
        }, _callee10, this, [[0, 9]]);
      }));

      function updateSession() {
        return _updateSession.apply(this, arguments);
      }

      return updateSession;
    }()
  }, {
    key: "confirm",
    value: function confirm(values) {
      return this.app.api.fetch('/api/auth/permit/confirm', {
        method: 'POST',
        data: values
      });
    }
  }, {
    key: "restorePassword",
    value: function restorePassword(_ref) {
      var email = _ref.email;
      return this.app.api.fetch('/api/auth/restorePassword', {
        method: 'POST',
        data: {
          email: email
        }
      });
    }
  }, {
    key: "setPassword",
    value: function setPassword(_ref2) {
      var permitId = _ref2.permitId,
          code = _ref2.code,
          password = _ref2.password;
      return this.app.api.fetch('/api/auth/setPassword', {
        method: 'POST',
        data: {
          permitId: permitId,
          code: code,
          password: password
        }
      });
    }
  }, {
    key: "confirmEmail",
    value: function confirmEmail(_ref3) {
      var permitId = _ref3.permitId,
          code = _ref3.code;
      return this.app.api.fetch('/api/auth/confirmEmail', {
        method: 'POST',
        data: {
          permitId: permitId,
          code: code
        }
      });
    }
  }, {
    key: "setData",
    value: function setData() {
      var _this$store4;

      return (_this$store4 = this.store).setData.apply(_this$store4, arguments);
    }
  }, {
    key: "loginPassport",
    value: function loginPassport(data) {
      return this.applyPromiseAndFetchProfile(this.app.api.authLoginPassport(data));
    }
  }, {
    key: "authPassport",
    value: function authPassport(provider) {
      if (typeof window !== 'undefined') window.location = "/api/module/auth/".concat(provider);
    }
  }]);
  return AuthClientModule;
}(_module["default"]); // export default ctx => ({
//   init() {
//     // this.components = require('./uapp/components').default(ctx);
//     // this.socials = require('./uapp/socials').default;// (ctx);
//     // this.models = require('./uapp/models').default(ctx);
//     this.stores = require('./uapp/stores').default(ctx);
//     // this.router = require('./uapp/router').default;
//   },
//   // getStores
// });


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