@lskjs/bots/BotsModule.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.asyncMapValues = void 0;

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

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

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 _botsRouter = require("@lskjs/bots-router");

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

var _createAsyncModule = require("@lskjs/module/utils/createAsyncModule");

var _importFn = _interopRequireDefault(require("@lskjs/utils/importFn"));

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

var _flatten = _interopRequireDefault(require("lodash/flatten"));

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

var _pickBy = _interopRequireDefault(require("lodash/pickBy"));

var _models = _interopRequireDefault(require("./models"));

var _plugins = _interopRequireDefault(require("./plugins"));

var _providers = _interopRequireDefault(require("./providers"));

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

var asyncMapValues = function asyncMapValues(obj, callback) {
  return _bluebird["default"].props((0, _mapValues["default"])(obj, callback));
};

exports.asyncMapValues = asyncMapValues;

var BotsModule = /*#__PURE__*/function (_Module) {
  (0, _inherits2["default"])(BotsModule, _Module);

  var _super = _createSuper(BotsModule);

  function BotsModule() {
    var _this;

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

    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.app = void 0;
    _this.providers = _providers["default"];
    _this.plugins = {};
    _this.log = void 0;
    _this.bots = void 0;
    _this.v = void 0;
    _this.routes = void 0;
    _this.routers = void 0;
    _this.config = void 0;
    return _this;
  }

  (0, _createClass2["default"])(BotsModule, [{
    key: "setProps",
    value: function setProps() {
      var _get2;

      for (var _len2 = arguments.length, props = new Array(_len2), _key2 = 0; _key2 < _len2; _key2++) {
        props[_key2] = arguments[_key2];
      }

      (_get2 = (0, _get3["default"])((0, _getPrototypeOf2["default"])(BotsModule.prototype), "setProps", this)).call.apply(_get2, [this].concat(props));

      try {
        // eslint-disable-next-line import/no-unresolved
        this.v = require('./package.json').version;
      } catch (err) {
        // eslint-disable-next-line no-console
        console.error('setProps err', err);
      }
    }
  }, {
    key: "getConfig",
    value: function () {
      var _getConfig = (0, _asyncToGenerator2["default"])( /*#__PURE__*/_regenerator["default"].mark(function _callee() {
        var config;
        return _regenerator["default"].wrap(function _callee$(_context) {
          while (1) {
            switch (_context.prev = _context.next) {
              case 0:
                config = _objectSpread(_objectSpread(_objectSpread({}, this.config || {}), this.__config || {}), {}, {
                  providers: _objectSpread(_objectSpread({}, this.config.providers || {}), this.__config.providers || {}),
                  plugins: _objectSpread(_objectSpread({}, this.config.plugins || {}), this.__config.plugins || {})
                });
                return _context.abrupt("return", config);

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

      function getConfig() {
        return _getConfig.apply(this, arguments);
      }

      return getConfig;
    }()
  }, {
    key: "model",
    value: function () {
      var _model = (0, _asyncToGenerator2["default"])( /*#__PURE__*/_regenerator["default"].mark(function _callee2() {
        var modelsModule,
            _args2 = arguments;
        return _regenerator["default"].wrap(function _callee2$(_context2) {
          while (1) {
            switch (_context2.prev = _context2.next) {
              case 0:
                _context2.next = 2;
                return this.module('models');

              case 2:
                modelsModule = _context2.sent;
                return _context2.abrupt("return", modelsModule.model.apply(modelsModule, _args2));

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

      function model() {
        return _model.apply(this, arguments);
      }

      return model;
    }()
  }, {
    key: "getPlugins",
    value: function () {
      var _getPlugins = (0, _asyncToGenerator2["default"])( /*#__PURE__*/_regenerator["default"].mark(function _callee3() {
        return _regenerator["default"].wrap(function _callee3$(_context3) {
          while (1) {
            switch (_context3.prev = _context3.next) {
              case 0:
                return _context3.abrupt("return", _objectSpread(_objectSpread({}, _plugins["default"]), this.plugins || {}));

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

      function getPlugins() {
        return _getPlugins.apply(this, arguments);
      }

      return getPlugins;
    }()
  }, {
    key: "getProviders",
    value: function () {
      var _getProviders = (0, _asyncToGenerator2["default"])( /*#__PURE__*/_regenerator["default"].mark(function _callee4() {
        return _regenerator["default"].wrap(function _callee4$(_context4) {
          while (1) {
            switch (_context4.prev = _context4.next) {
              case 0:
                return _context4.abrupt("return", _objectSpread(_objectSpread({}, _providers["default"]), this.providers || {}));

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

      function getProviders() {
        return _getProviders.apply(this, arguments);
      }

      return getProviders;
    }()
  }, {
    key: "getRoutes",
    value: function () {
      var _getRoutes = (0, _asyncToGenerator2["default"])( /*#__PURE__*/_regenerator["default"].mark(function _callee6() {
        var plugingRoutes;
        return _regenerator["default"].wrap(function _callee6$(_context6) {
          while (1) {
            switch (_context6.prev = _context6.next) {
              case 0:
                _context6.next = 2;
                return asyncMapValues(this.plugins, /*#__PURE__*/function () {
                  var _ref = (0, _asyncToGenerator2["default"])( /*#__PURE__*/_regenerator["default"].mark(function _callee5(plugin) {
                    var routes;
                    return _regenerator["default"].wrap(function _callee5$(_context5) {
                      while (1) {
                        switch (_context5.prev = _context5.next) {
                          case 0:
                            if (!(plugin && plugin.getRoutes)) {
                              _context5.next = 7;
                              break;
                            }

                            _context5.next = 3;
                            return plugin.getRoutes();

                          case 3:
                            routes = _context5.sent;

                            if (Array.isArray(routes)) {
                              _context5.next = 6;
                              break;
                            }

                            return _context5.abrupt("return", [routes]);

                          case 6:
                            return _context5.abrupt("return", routes);

                          case 7:
                            return _context5.abrupt("return", []);

                          case 8:
                          case "end":
                            return _context5.stop();
                        }
                      }
                    }, _callee5);
                  }));

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

              case 2:
                plugingRoutes = _context6.sent;
                return _context6.abrupt("return", [].concat((0, _toConsumableArray2["default"])((0, _flatten["default"])(Object.values(plugingRoutes))), [{
                  path: '/start',
                  action: this.onStart.bind(this)
                }, {
                  path: '(.*)',
                  action: function action(_ref2) {
                    var path = _ref2.path,
                        log = _ref2.log;
                    log.error('404', path);
                    return true;
                  }
                }]));

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

      function getRoutes() {
        return _getRoutes.apply(this, arguments);
      }

      return getRoutes;
    }()
  }, {
    key: "onStart",
    value: function () {
      var _onStart = (0, _asyncToGenerator2["default"])( /*#__PURE__*/_regenerator["default"].mark(function _callee7(_ref3) {
        var ctx;
        return _regenerator["default"].wrap(function _callee7$(_context7) {
          while (1) {
            switch (_context7.prev = _context7.next) {
              case 0:
                ctx = _ref3.ctx;
                _context7.next = 3;
                return ctx.reply("Hello LSK world");

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

      function onStart(_x2) {
        return _onStart.apply(this, arguments);
      }

      return onStart;
    }()
  }, {
    key: "getModules",
    value: function () {
      var _getModules = (0, _asyncToGenerator2["default"])( /*#__PURE__*/_regenerator["default"].mark(function _callee8() {
        return _regenerator["default"].wrap(function _callee8$(_context8) {
          while (1) {
            switch (_context8.prev = _context8.next) {
              case 0:
                return _context8.abrupt("return", _objectSpread(_objectSpread({}, (0, _get3["default"])((0, _getPrototypeOf2["default"])(BotsModule.prototype), "getModules", this).call(this)), {}, {
                  // @ts-ignore
                  models: [function () {
                    return Promise.resolve().then(function () {
                      return _interopRequireWildcard(require('@lskjs/db/models'));
                    });
                  }, {
                    models: _models["default"]
                  }]
                }));

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

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

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

        var _this$config, _this$config$assignPr, assignProviders, providersConfigs, pluginsConfig, providers, currentPlugins;

        return _regenerator["default"].wrap(function _callee12$(_context12) {
          while (1) {
            switch (_context12.prev = _context12.next) {
              case 0:
                _context12.next = 2;
                return (0, _get3["default"])((0, _getPrototypeOf2["default"])(BotsModule.prototype), "init", this).call(this);

              case 2:
                // console.log('this.app.config.bots', this.app.config.bots)
                // console.log(this.config)
                _this$config = this.config, _this$config$assignPr = _this$config.assignProviders, assignProviders = _this$config$assignPr === void 0 ? true : _this$config$assignPr, providersConfigs = _this$config.providers, pluginsConfig = _this$config.plugins;
                _context12.next = 5;
                return this.getProviders();

              case 5:
                providers = _context12.sent;
                // eslint-disable-line no-shadow
                this.log.debug('providers', Object.keys(providers));
                _context12.next = 9;
                return asyncMapValues(providersConfigs, /*#__PURE__*/function () {
                  var _ref4 = (0, _asyncToGenerator2["default"])( /*#__PURE__*/_regenerator["default"].mark(function _callee9(config, key) {
                    var provider;
                    return _regenerator["default"].wrap(function _callee9$(_context9) {
                      while (1) {
                        switch (_context9.prev = _context9.next) {
                          case 0:
                            provider = config.provider;

                            if (provider) {
                              _context9.next = 4;
                              break;
                            }

                            _this2.log.warn("Empty provider for bot '".concat(key, "'"));

                            return _context9.abrupt("return", null);

                          case 4:
                            if (providers[provider]) {
                              _context9.next = 7;
                              break;
                            }

                            _this2.log.warn("Can't find provider '".concat(provider, "' for bot '").concat(key, "'"));

                            return _context9.abrupt("return", null);

                          case 7:
                            return _context9.abrupt("return", (0, _createAsyncModule.createAsyncModule)(providers[provider], {
                              __parent: _this2,
                              app: _this2.app,
                              botsModule: _this2,
                              config: config,
                              key: key
                            }));

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

                  return function (_x3, _x4) {
                    return _ref4.apply(this, arguments);
                  };
                }());

              case 9:
                this.bots = _context12.sent;
                this.log.debug('bots', Object.keys(this.bots));
                _context12.next = 13;
                return this.getPlugins();

              case 13:
                currentPlugins = _context12.sent;
                _context12.next = 16;
                return asyncMapValues(currentPlugins, /*#__PURE__*/function () {
                  var _ref5 = (0, _asyncToGenerator2["default"])( /*#__PURE__*/_regenerator["default"].mark(function _callee10(pluginFn, name) {
                    var pluginConfig, Plugin;
                    return _regenerator["default"].wrap(function _callee10$(_context10) {
                      while (1) {
                        switch (_context10.prev = _context10.next) {
                          case 0:
                            pluginConfig = pluginsConfig && pluginsConfig[name];
                            return _context10.abrupt("return", (0, _createAsyncModule.createAsyncModule)(pluginFn, {
                              __parent: _this2,
                              app: _this2.app,
                              botsModule: _this2,
                              bots: _this2.bots,
                              config: pluginConfig || {}
                            }));

                          case 4:
                            Plugin = _context10.sent;

                            if (!(pluginConfig === false)) {
                              _context10.next = 7;
                              break;
                            }

                            return _context10.abrupt("return", null);

                          case 7:
                            return _context10.abrupt("return", Plugin.create({
                              __parent: _this2,
                              app: _this2.app,
                              botsModule: _this2,
                              bots: _this2.bots,
                              config: pluginConfig || {}
                            }));

                          case 8:
                          case "end":
                            return _context10.stop();
                        }
                      }
                    }, _callee10);
                  }));

                  return function (_x5, _x6) {
                    return _ref5.apply(this, arguments);
                  };
                }());

              case 16:
                this.plugins = _context12.sent;
                // @ts-ignore
                this.plugins = (0, _pickBy["default"])(this.plugins, Boolean);
                this.log.debug('plugins', Object.keys(this.plugins));
                _context12.next = 21;
                return this.getRoutes();

              case 21:
                this.routes = _context12.sent;
                this.log.debug('Bots.routes', this.routes.map(function (c) {
                  return c.path;
                }));
                _context12.next = 25;
                return asyncMapValues(this.bots, /*#__PURE__*/function () {
                  var _ref6 = (0, _asyncToGenerator2["default"])( /*#__PURE__*/_regenerator["default"].mark(function _callee11(bot) {
                    return _regenerator["default"].wrap(function _callee11$(_context11) {
                      while (1) {
                        switch (_context11.prev = _context11.next) {
                          case 0:
                            return _context11.abrupt("return", _botsRouter.BotsRouter.create({
                              __parent: _this2,
                              app: _this2.app,
                              botsModule: _this2,
                              bots: _this2.bots,
                              bot: bot,
                              routes: _this2.routes
                            }));

                          case 1:
                          case "end":
                            return _context11.stop();
                        }
                      }
                    }, _callee11);
                  }));

                  return function (_x7) {
                    return _ref6.apply(this, arguments);
                  };
                }());

              case 25:
                this.routers = _context12.sent;
                if (assignProviders) Object.assign(this, this.bots);

              case 27:
              case "end":
                return _context12.stop();
            }
          }
        }, _callee12, this);
      }));

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

      return init;
    }()
  }, {
    key: "run",
    value: function () {
      var _run = (0, _asyncToGenerator2["default"])( /*#__PURE__*/_regenerator["default"].mark(function _callee14() {
        return _regenerator["default"].wrap(function _callee14$(_context14) {
          while (1) {
            switch (_context14.prev = _context14.next) {
              case 0:
                _context14.next = 2;
                return (0, _get3["default"])((0, _getPrototypeOf2["default"])(BotsModule.prototype), "run", this).call(this);

              case 2:
                if (this.config) {
                  _context14.next = 4;
                  break;
                }

                return _context14.abrupt("return");

              case 4:
                _context14.next = 6;
                return asyncMapValues(this.bots, function (bot) {
                  return bot.__run();
                });

              case 6:
                _context14.next = 8;
                return asyncMapValues(this.plugins, function (plugin) {
                  return plugin.__run();
                });

              case 8:
                _context14.t0 = this.log;
                _context14.next = 11;
                return asyncMapValues(this.bots, /*#__PURE__*/function () {
                  var _ref7 = (0, _asyncToGenerator2["default"])( /*#__PURE__*/_regenerator["default"].mark(function _callee13(bot) {
                    return _regenerator["default"].wrap(function _callee13$(_context13) {
                      while (1) {
                        switch (_context13.prev = _context13.next) {
                          case 0:
                            return _context13.abrupt("return", (bot.plugins || []).map(function (plugin) {
                              return plugin.name;
                            }));

                          case 1:
                          case "end":
                            return _context13.stop();
                        }
                      }
                    }, _callee13);
                  }));

                  return function (_x8) {
                    return _ref7.apply(this, arguments);
                  };
                }());

              case 11:
                _context14.t1 = _context14.sent;

                _context14.t0.debug.call(_context14.t0, 'bots x plugins', _context14.t1);

              case 13:
              case "end":
                return _context14.stop();
            }
          }
        }, _callee14, this);
      }));

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

      return run;
    }()
  }]);
  return BotsModule;
}(_module.Module);

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