-
Notifications
You must be signed in to change notification settings - Fork 22
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
- Loading branch information
1 parent
d77d659
commit 1a47faa
Showing
2 changed files
with
46 additions
and
285 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -1,145 +1,19 @@ | ||
| const debug = require('debug')('barracks') | ||
| const assert = require('assertf') | ||
| const async = require('async') | ||
| // const debug = require('debug')('barracks') | ||
| // const assert = require('assertf') | ||
| // const async = require('async') | ||
|
|
||
| module.exports = Dispatcher | ||
| module.exports = dispatcher | ||
|
|
||
| // initialize the dispatcher with actions | ||
| // obj -> fn | ||
| function Dispatcher (actions) { | ||
| if (!(this instanceof Dispatcher)) return new Dispatcher(actions) | ||
| // initialize a new barracks instance | ||
| // null -> obj | ||
| function dispatcher () { | ||
|
|
||
| assert(actions, "an 'actions' object should be passed as an argument") | ||
| assert.equal(typeof actions, 'object', 'actions should be an object') | ||
| _assertActionsObject(actions) | ||
| emit.on = on | ||
| return emit | ||
|
|
||
| this.locals = {} | ||
| this.payload = null | ||
|
|
||
| this._current = [] | ||
| this._isPending = {} | ||
| this._isHandled = {} | ||
| this._actions = actions | ||
| this._isDispatching = false | ||
|
|
||
| return this.dispatch.bind(this) | ||
| } | ||
|
|
||
| // dispatch event to stores | ||
| // str, obj|[obj] -> fn | ||
| Dispatcher.prototype.dispatch = function (action, payload) { | ||
| assert.equal(typeof action, 'string', "action '%s' should be a string", action) | ||
| assert(!this._isDispatching, "cannot dispatch '%s' in the middle of a dispatch", action) | ||
|
|
||
| this._current.push(action) | ||
| this._isDispatching = true | ||
|
|
||
| this._isPending = {} | ||
| this._isPending[action] = true | ||
|
|
||
| this._isHandled = {} | ||
| this._isHandled[action] = false | ||
|
|
||
| this.locals = {} | ||
| this.payload = payload | ||
|
|
||
| try { | ||
| const fn = _getAction.call(this, action) | ||
| } catch (e) { | ||
| _stopDispatching.call(this) | ||
| throw e | ||
| function on (action, cb) { | ||
| } | ||
|
|
||
| debug("dispatch '%s'", action) | ||
| fn.call(this, _stopDispatching.bind(this)) | ||
| } | ||
|
|
||
| // expose a delegation method to the registered | ||
| // actions. Calls `async.series()` under the hood | ||
| // str|[str], fn -> null | ||
| Dispatcher.prototype.waitFor = function (actions, done) { | ||
| done = done || function () {} | ||
| assert.equal(typeof done, 'function', 'callback should be a function') | ||
|
|
||
| actions = Array.isArray(actions) ? actions : [actions] | ||
| const ctx = this | ||
|
|
||
| const arr = actions.map(function (action) { | ||
| const fn = _getAction.call(ctx, action) | ||
| const nwFn = _thunkify.call(ctx, fn, action) | ||
| return nwFn.bind(ctx) | ||
| }) | ||
|
|
||
| const nwArr = arr.concat(done.bind(this)) | ||
| async.series(nwArr) | ||
| } | ||
|
|
||
| // deep assert the actions object | ||
| // obj -> null | ||
| function _assertActionsObject (actions) { | ||
| Object.keys(actions).forEach(function (key) { | ||
| const action = actions[key] | ||
| if ('object' == typeof action) return _assertActionsObject(action) | ||
| assert.equal(typeof action, 'function', 'action should be a function') | ||
| }) | ||
| } | ||
|
|
||
| // wrap function to set | ||
| // `this._isHandled[action]` on end | ||
| // fn, fn -> fn | ||
| function _thunkify (fn, action) { | ||
| return function (done) { | ||
| try { | ||
| assert.equal(typeof action, 'string', '.waitFor(): requires a string or array of strings') | ||
| if (this._isPending[action]) { | ||
| assert(this._isHandled[action], "circular dependency detected while waiting for '%s'", action) | ||
| } | ||
| } catch(e) { | ||
| _stopDispatching.call(this) | ||
| throw e | ||
| } | ||
|
|
||
| this._isPending[action] = true | ||
| this._isHandled[action] = false | ||
|
|
||
| function fin () { | ||
| this._current.pop() | ||
| this._isHandled[action] = true | ||
| done() | ||
| } | ||
|
|
||
| this._current.push(action) | ||
| debug("'%s' -> '%s'", this._current[this._current.length - 2], action) | ||
| fn(fin.bind(this)) | ||
| function emit (event, data) { | ||
| } | ||
| } | ||
|
|
||
| // get the dispatched action recursively | ||
| // [str], str -> fn | ||
| function _getAction (action, arr, index) { | ||
| arr = arr || action.split('_') | ||
| index = index || 0 | ||
| const val = arr[index] | ||
|
|
||
| if ('object' == typeof val) return _getAction.call(this, action, arr, index++) | ||
|
|
||
| var fn = this._actions | ||
| arr.forEach(function (obj, i) { | ||
| assert(fn[arr[i]], "action '%s' is not registered", action) | ||
| fn = fn[arr[i]] | ||
| }) | ||
|
|
||
| assert.equal(typeof fn, 'function', "action '%s' is not registered", action) | ||
| return fn.bind(this) | ||
| } | ||
|
|
||
| // reset internal state | ||
| // null -> null | ||
| function _stopDispatching () { | ||
| this._isDispatching = false | ||
| this._isPending = {} | ||
| this._isHandled = {} | ||
| this.payload = null | ||
| this._current = [] | ||
| this.locals = {} | ||
| } |