forked from reddit/node-middleware
/
Thunker.js
159 lines (126 loc) · 5.38 KB
/
Thunker.js
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
(function webpackUniversalModuleDefinition(root, factory) {
if(typeof exports === 'object' && typeof module === 'object')
module.exports = factory();
else if(typeof define === 'function' && define.amd)
define([], factory);
else if(typeof exports === 'object')
exports["Thunker.js"] = factory();
else
root["Thunker.js"] = factory();
})(this, function() {
return /******/ (function(modules) { // webpackBootstrap
/******/ // The module cache
/******/ var installedModules = {};
/******/ // The require function
/******/ function __webpack_require__(moduleId) {
/******/ // Check if module is in cache
/******/ if(installedModules[moduleId])
/******/ return installedModules[moduleId].exports;
/******/ // Create a new module (and put it into the cache)
/******/ var module = installedModules[moduleId] = {
/******/ exports: {},
/******/ id: moduleId,
/******/ loaded: false
/******/ };
/******/ // Execute the module function
/******/ modules[moduleId].call(module.exports, module, module.exports, __webpack_require__);
/******/ // Flag the module as loaded
/******/ module.loaded = true;
/******/ // Return the exports of the module
/******/ return module.exports;
/******/ }
/******/ // expose the modules object (__webpack_modules__)
/******/ __webpack_require__.m = modules;
/******/ // expose the module cache
/******/ __webpack_require__.c = installedModules;
/******/ // __webpack_public_path__
/******/ __webpack_require__.p = "";
/******/ // Load entry module and return exports
/******/ return __webpack_require__(0);
/******/ })
/************************************************************************/
/******/ ([
/* 0 */
/***/ function(module, exports) {
'use strict';
Object.defineProperty(exports, "__esModule", {
value: true
});
var _slicedToArray = function () { function sliceIterator(arr, i) { var _arr = []; var _n = true; var _d = false; var _e = undefined; try { for (var _i = arr[Symbol.iterator](), _s; !(_n = (_s = _i.next()).done); _n = true) { _arr.push(_s.value); if (i && _arr.length === i) break; } } catch (err) { _d = true; _e = err; } finally { try { if (!_n && _i["return"]) _i["return"](); } finally { if (_d) throw _e; } } return _arr; } return function (arr, i) { if (Array.isArray(arr)) { return arr; } else if (Symbol.iterator in Object(arr)) { return sliceIterator(arr, i); } else { throw new TypeError("Invalid attempt to destructure non-iterable instance"); } }; }();
exports.default = {
create: function create() {
var storeQueue = [];
var actionQueue = [];
var waitForAction = function waitForAction(actionFn) {
var cb = arguments.length <= 1 || arguments[1] === undefined ? function () {} : arguments[1];
return new Promise(function (resolve, reject) {
actionQueue = actionQueue.concat([[actionFn, function (state) {
return resolve(state);
}]]);
}).then(cb);
};
return function (store) {
return function (next) {
return function (action) {
var dispatch = store.dispatch;
var getState = store.getState;
var state = getState();
var waitForState = function waitForState(stateFn) {
var cb = arguments.length <= 1 || arguments[1] === undefined ? function () {} : arguments[1];
var stateFailedFn = arguments.length <= 2 || arguments[2] === undefined ? function () {} : arguments[2];
return new Promise(function (resolve, reject) {
if (!stateFn(state)) {
storeQueue = storeQueue.concat([[stateFn, function (newState) {
return resolve(newState);
}]]);
stateFailedFn(state);
} else {
resolve(state);
}
}).then(cb);
};
if (typeof action === 'function') {
var result = action(dispatch, getState, { waitForState: waitForState, waitForAction: waitForAction });
if (!(result instanceof Promise)) {
throw new Error('Thunked actions must return promises');
}
return next(result);
}
actionQueue = actionQueue.filter(function (_ref) {
var _ref2 = _slicedToArray(_ref, 2);
var actionFn = _ref2[0];
var cb = _ref2[1];
if (actionFn(action)) {
cb(state);
return false;
}
return true;
});
// order of operations is very important here.
// for the store queue to process properly, we need to let the new action
// make its way into the store first before we check if any queued
// waitForState situations are resolveable
next(action);
// also important, the store queue filter function must re-fetch state
// using getState, otherwise the aforementioned action's effects will not
// be reflected in the filter function.
storeQueue = storeQueue.filter(function (_ref3) {
var _ref4 = _slicedToArray(_ref3, 2);
var stateFn = _ref4[0];
var cb = _ref4[1];
var state = getState();
if (stateFn(state)) {
cb(state);
return false;
}
return true;
});
};
};
};
}
};
/***/ }
/******/ ])
});
;