baseDispatcher.js

  1. define(['utils', 'IPlugin'], function(Utils, IPlugin) {
  2.     "use strict";
  4.     //todo может например перейти на https://github.com/component/emitter
  5.     /**
  6.      * @class
  7.      * Класс диспетчера, инкапсулирует событийную модель, каждый экземпляр представляет собой событие.
  8.      * @param {JQuery} mainDiv - элемент, в котором располагается панель. Должен содержать класс rb-wrapper.
  9.      * @constructor BaseDispatcher
  10.      * @extends IPlugin
  11.      */
  12.     function BaseDispatcher(mainDiv) {
  13.         this._actions = {};
  14.         this._index = 0;
  15.         this._mainDiv = mainDiv;
  16.     }
  17.     Utils.inherite(BaseDispatcher, IPlugin);
  18.     BaseDispatcher.prototype.configure = function(config) {
  19.         if (typeof config === 'object') {
  20.             if (config.loadingDiv !== undefined) {
  21.                 this._loadingDiv = $(config.loadingDiv);
  22.             }
  23.         }
  24.     };
  26.     // todo сделать не once, а дать возможность указать число - количество срабатываний,
  27.     // или функцию которая если вернет true - не отписываться, false - отписываться
  28.     /**
  29.      * Зарегистрировать действие, которое выполнится при запуске действий
  30.      * @param {function} action - регистрируемое действие
  31.      * @param {boolean} [once] - выполнить действие только в первый раз
  32.      * @returns {number|null} индекс зарегистрированного действия (null, если действие не было зарегистрировано)
  33.      * @memberOf BaseDispatcher
  34.      */
  35.     BaseDispatcher.prototype.add = function(action, once) {
  36.         if (typeof action === 'function') {
  37.             this._actions[this._index++] = {
  38.                 action: action,
  39.                 once: once
  40.             };
  41.             return this._index-1;
  42.         }
  43.         return null;
  44.     };
  45.     // todo отписка не по индексу, а по функции
  46.     /**
  47.      * Удалить действие из списка зарегистрированных действий
  48.      * @param {number} index - индекс удаляемого действия
  49.      * @memberOf BaseDispatcher
  50.      */
  51.     BaseDispatcher.prototype.remove = function(index) {
  52.         if (this._actions.hasOwnProperty(index)) {
  53.             delete this._actions[index];
  54.         }
  55.     };
  56.     /**
  57.      * Запустить зарегистрированные действия
  58.      * @param {function|undefined} [fn] - функция, которая будет выполнена после того, как выполнятся все зарегистрированные действия.
  59.      * Если зарегистрированные функции возвращают Promise, функция выполнится после завершения этих Promise.
  60.      * Если хотя бы одна из зарегистрированных функций (или их Promise) вернет false, фунция fn не будет вызвана.
  61.      * @param {Array} [actionArgs] - аргументы для зарегистрированных функций (для всех функций будут переданы одни и те же аргументы).
  62.      * @returns {*} Результат выполнения функции fn, либо undefined если функция fn не была вызвана
  63.      * @memberOf BaseDispatcher
  64.      */
  65.     BaseDispatcher.prototype.runActions = function(fn, actionArgs) {
  66.         var
  67.             actions = [],
  68.             results = [],
  69.             self = this;
  71.         if (Object.keys(this._actions).length) {
  72.             this._mainDiv.append(this._loadingDiv); // todo вынести это в moving, а здесь просто вызывать функцию
  74.             Object.keys(this._actions).map(function(index) {
  75.                 var value = this._actions[index],
  76.                     result = value.action.apply(undefined, actionArgs);
  78.                 if (value.once) {
  79.                     this.remove(index);
  80.                 }
  81.                 if (result instanceof Promise) {
  82.                     actions.push(result);
  83.                 } else {
  84.                     results.push(result);
  85.                 }
  86.             }.bind(this));
  88.             return Promise.all(actions).then(function(promiseResult) {
  89.                 self._loadingDiv.remove();
  91.                 var isOk = results.concat(promiseResult).every(function(res) {
  92.                     return res !== false;
  93.                 });
  94.                 if (isOk) {
  95.                     return fn && fn();
  96.                 }
  97.             }, function(error) {
  98.                 self._loadingDiv.remove();
  99.                 console.error(error);
  101.                 var isOk = results.every(function(res) {
  102.                     return res !== false;
  103.                 });
  104.                 if (isOk) {
  105.                     return fn && fn();
  106.                 }
  107.             });
  108.         } else {
  109.             return fn && fn();
  110.         }
  111.     };
  113.     /**
  114.      * Уничтожить экземпляр класса
  115.      * @memberOf BaseDispatcher
  116.      */
  117.     BaseDispatcher.prototype.destroy = function() {
  118.         this._actions = null;
  119.     };
  121.     return BaseDispatcher;
  122. });