Skip to content

Commit c31c65a

Browse files
pubkeypubkey
committed
7.1.0
1 parent fae2afd commit c31c65a

30 files changed

+3792
-2673
lines changed

‎dist/es5node/leader-election-util.js‎

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -42,7 +42,6 @@ function beLeader(leaderElector) {
4242
sendLeaderMessage(leaderElector, 'tell'); // ensure other leader also knows the problem
4343
}
4444
};
45-
4645
leaderElector.broadcastChannel.addEventListener('internal', isLeaderListener);
4746
leaderElector._lstns.push(isLeaderListener);
4847
return sendLeaderMessage(leaderElector, 'tell');

‎dist/es5node/leader-election.js‎

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -174,7 +174,7 @@ LeaderElection.prototype = {
174174
});
175175
},
176176
awaitLeadership: function awaitLeadership() {
177-
if ( /* _awaitLeadershipPromise */
177+
if (/* _awaitLeadershipPromise */
178178
!this._aLP) {
179179
this._aLP = _awaitLeadershipOnce(this);
180180
}
@@ -231,7 +231,7 @@ function _awaitLeadershipOnce(leaderElector) {
231231
* Try on fallbackInterval
232232
* @recursive
233233
*/
234-
var tryOnFallBack = function tryOnFallBack() {
234+
var _tryOnFallBack = function tryOnFallBack() {
235235
return (0, _util.sleep)(leaderElector._options.fallbackInterval).then(function () {
236236
if (leaderElector.isDead || resolved) {
237237
return;
@@ -243,13 +243,13 @@ function _awaitLeadershipOnce(leaderElector) {
243243
if (leaderElector.isLeader) {
244244
finish();
245245
} else {
246-
tryOnFallBack();
246+
_tryOnFallBack();
247247
}
248248
});
249249
}
250250
});
251251
};
252-
tryOnFallBack();
252+
_tryOnFallBack();
253253

254254
// try when other leader dies
255255
var whenDeathListener = function whenDeathListener(msg) {

‎dist/es5node/method-chooser.js‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -11,7 +11,7 @@ var _localstorage = require("./methods/localstorage.js");
1111
var _simulate = require("./methods/simulate.js");
1212
var NodeMethod = _interopRequireWildcard(require("./methods/node.js"));
1313
function _getRequireWildcardCache(e) { if ("function" != typeof WeakMap) return null; var r = new WeakMap(), t = new WeakMap(); return (_getRequireWildcardCache = function _getRequireWildcardCache(e) { return e ? t : r; })(e); }
14-
function _interopRequireWildcard(e, r) { if (!r && e && e.__esModule) return e; if (null === e || "object" != _typeof(e) && "function" != typeof e) return { "default": e }; var t = _getRequireWildcardCache(r); if (t && t.has(e)) return t.get(e); var n = { __proto__: null }, a = Object.defineProperty && Object.getOwnPropertyDescriptor; for (var u in e) if ("default" !== u && Object.prototype.hasOwnProperty.call(e, u)) { var i = a ? Object.getOwnPropertyDescriptor(e, u) : null; i && (i.get || i.set) ? Object.defineProperty(n, u, i) : n[u] = e[u]; } return n["default"] = e, t && t.set(e, n), n; }
14+
function _interopRequireWildcard(e, r) { if (!r && e && e.__esModule) return e; if (null === e || "object" != _typeof(e) && "function" != typeof e) return { "default": e }; var t = _getRequireWildcardCache(r); if (t && t.has(e)) return t.get(e); var n = { __proto__: null }, a = Object.defineProperty && Object.getOwnPropertyDescriptor; for (var u in e) if ("default" !== u && {}.hasOwnProperty.call(e, u)) { var i = a ? Object.getOwnPropertyDescriptor(e, u) : null; i && (i.get || i.set) ? Object.defineProperty(n, u, i) : n[u] = e[u]; } return n["default"] = e, t && t.set(e, n), n; }
1515
// the line below will be removed from es5/browser builds
1616

1717
// order is important

‎dist/es5node/methods/localstorage.js‎

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -114,7 +114,6 @@ function create(channelName, options) {
114114
uuid: uuid,
115115
eMIs: eMIs // emittedMessagesIds
116116
};
117-
118117
state.listener = addStorageEventListener(channelName, function (msgObj) {
119118
if (!state.messagesCallback) return; // no listener
120119
if (msgObj.uuid === uuid) return; // own message

‎dist/es5node/methods/native.js‎

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -22,7 +22,6 @@ function create(channelName) {
2222
bc: new BroadcastChannel(channelName),
2323
subFns: [] // subscriberFunctions
2424
};
25-
2625
state.bc.onmessage = function (msgEvent) {
2726
if (state.messagesCallback) {
2827
state.messagesCallback(msgEvent.data);

‎dist/es5node/methods/node.js‎

Lines changed: 22 additions & 22 deletions
Original file line numberDiff line numberDiff line change
@@ -75,7 +75,7 @@ var readdir = _util["default"].promisify(_fs["default"].readdir);
7575
var chmod = _util["default"].promisify(_fs["default"].chmod);
7676
var rmDir = _util["default"].promisify(_fs["default"].rm);
7777
var removeDir = /*#__PURE__*/function () {
78-
var _ref = (0, _asyncToGenerator2["default"])( /*#__PURE__*/_regenerator["default"].mark(function _callee(p) {
78+
var _ref = (0, _asyncToGenerator2["default"])(/*#__PURE__*/_regenerator["default"].mark(function _callee(p) {
7979
return _regenerator["default"].wrap(function _callee$(_context) {
8080
while (1) switch (_context.prev = _context.next) {
8181
case 0:
@@ -142,7 +142,7 @@ function ensureBaseFolderExists() {
142142
return _ensureBaseFolderExists.apply(this, arguments);
143143
}
144144
function _ensureBaseFolderExists() {
145-
_ensureBaseFolderExists = (0, _asyncToGenerator2["default"])( /*#__PURE__*/_regenerator["default"].mark(function _callee4() {
145+
_ensureBaseFolderExists = (0, _asyncToGenerator2["default"])(/*#__PURE__*/_regenerator["default"].mark(function _callee4() {
146146
return _regenerator["default"].wrap(function _callee4$(_context4) {
147147
while (1) switch (_context4.prev = _context4.next) {
148148
case 0:
@@ -168,7 +168,7 @@ function ensureFoldersExist(_x2, _x3) {
168168
* @return {Promise<true>}
169169
*/
170170
function _ensureFoldersExist() {
171-
_ensureFoldersExist = (0, _asyncToGenerator2["default"])( /*#__PURE__*/_regenerator["default"].mark(function _callee5(channelName, paths) {
171+
_ensureFoldersExist = (0, _asyncToGenerator2["default"])(/*#__PURE__*/_regenerator["default"].mark(function _callee5(channelName, paths) {
172172
var chmodValue;
173173
return _regenerator["default"].wrap(function _callee5$(_context5) {
174174
while (1) switch (_context5.prev = _context5.next) {
@@ -207,7 +207,7 @@ function clearNodeFolder() {
207207
return _clearNodeFolder.apply(this, arguments);
208208
}
209209
function _clearNodeFolder() {
210-
_clearNodeFolder = (0, _asyncToGenerator2["default"])( /*#__PURE__*/_regenerator["default"].mark(function _callee6() {
210+
_clearNodeFolder = (0, _asyncToGenerator2["default"])(/*#__PURE__*/_regenerator["default"].mark(function _callee6() {
211211
return _regenerator["default"].wrap(function _callee6$(_context6) {
212212
while (1) switch (_context6.prev = _context6.next) {
213213
case 0:
@@ -263,7 +263,7 @@ function countChannelFolders() {
263263
return _countChannelFolders.apply(this, arguments);
264264
}
265265
function _countChannelFolders() {
266-
_countChannelFolders = (0, _asyncToGenerator2["default"])( /*#__PURE__*/_regenerator["default"].mark(function _callee7() {
266+
_countChannelFolders = (0, _asyncToGenerator2["default"])(/*#__PURE__*/_regenerator["default"].mark(function _callee7() {
267267
var folders;
268268
return _regenerator["default"].wrap(function _callee7$(_context7) {
269269
while (1) switch (_context7.prev = _context7.next) {
@@ -292,7 +292,7 @@ function connectionError(_x4) {
292292
* @return {{emitter: EventEmitter, server: any}}
293293
*/
294294
function _connectionError() {
295-
_connectionError = (0, _asyncToGenerator2["default"])( /*#__PURE__*/_regenerator["default"].mark(function _callee8(originalError) {
295+
_connectionError = (0, _asyncToGenerator2["default"])(/*#__PURE__*/_regenerator["default"].mark(function _callee8(originalError) {
296296
var count, addObj, text;
297297
return _regenerator["default"].wrap(function _callee8$(_context8) {
298298
while (1) switch (_context8.prev = _context8.next) {
@@ -327,7 +327,7 @@ function createSocketEventEmitter(_x5, _x6, _x7) {
327327
return _createSocketEventEmitter.apply(this, arguments);
328328
}
329329
function _createSocketEventEmitter() {
330-
_createSocketEventEmitter = (0, _asyncToGenerator2["default"])( /*#__PURE__*/_regenerator["default"].mark(function _callee11(channelName, readerUuid, paths) {
330+
_createSocketEventEmitter = (0, _asyncToGenerator2["default"])(/*#__PURE__*/_regenerator["default"].mark(function _callee11(channelName, readerUuid, paths) {
331331
var pathToSocket, emitter, server;
332332
return _regenerator["default"].wrap(function _callee11$(_context11) {
333333
while (1) switch (_context11.prev = _context11.next) {
@@ -343,7 +343,7 @@ function _createSocketEventEmitter() {
343343
_context11.next = 5;
344344
return new Promise(function (resolve, reject) {
345345
server.on('error', /*#__PURE__*/function () {
346-
var _ref5 = (0, _asyncToGenerator2["default"])( /*#__PURE__*/_regenerator["default"].mark(function _callee9(err) {
346+
var _ref5 = (0, _asyncToGenerator2["default"])(/*#__PURE__*/_regenerator["default"].mark(function _callee9(err) {
347347
var useErr;
348348
return _regenerator["default"].wrap(function _callee9$(_context9) {
349349
while (1) switch (_context9.prev = _context9.next) {
@@ -364,7 +364,7 @@ function _createSocketEventEmitter() {
364364
};
365365
}());
366366
server.listen(pathToSocket, /*#__PURE__*/function () {
367-
var _ref6 = (0, _asyncToGenerator2["default"])( /*#__PURE__*/_regenerator["default"].mark(function _callee10(err, res) {
367+
var _ref6 = (0, _asyncToGenerator2["default"])(/*#__PURE__*/_regenerator["default"].mark(function _callee10(err, res) {
368368
var useErr;
369369
return _regenerator["default"].wrap(function _callee10$(_context10) {
370370
while (1) switch (_context10.prev = _context10.next) {
@@ -416,7 +416,7 @@ function openClientConnection(_x8, _x9) {
416416
* @return {Promise}
417417
*/
418418
function _openClientConnection() {
419-
_openClientConnection = (0, _asyncToGenerator2["default"])( /*#__PURE__*/_regenerator["default"].mark(function _callee12(channelName, readerUuid) {
419+
_openClientConnection = (0, _asyncToGenerator2["default"])(/*#__PURE__*/_regenerator["default"].mark(function _callee12(channelName, readerUuid) {
420420
var pathToSocket, client;
421421
return _regenerator["default"].wrap(function _callee12$(_context12) {
422422
while (1) switch (_context12.prev = _context12.next) {
@@ -470,7 +470,7 @@ function getReadersUuids(_x10, _x11) {
470470
return _getReadersUuids.apply(this, arguments);
471471
}
472472
function _getReadersUuids() {
473-
_getReadersUuids = (0, _asyncToGenerator2["default"])( /*#__PURE__*/_regenerator["default"].mark(function _callee13(channelName, paths) {
473+
_getReadersUuids = (0, _asyncToGenerator2["default"])(/*#__PURE__*/_regenerator["default"].mark(function _callee13(channelName, paths) {
474474
var readersPath, files;
475475
return _regenerator["default"].wrap(function _callee13$(_context13) {
476476
while (1) switch (_context13.prev = _context13.next) {
@@ -501,7 +501,7 @@ function messagePath(_x12, _x13, _x14, _x15) {
501501
return _messagePath.apply(this, arguments);
502502
}
503503
function _messagePath() {
504-
_messagePath = (0, _asyncToGenerator2["default"])( /*#__PURE__*/_regenerator["default"].mark(function _callee14(channelName, time, token, writerUuid) {
504+
_messagePath = (0, _asyncToGenerator2["default"])(/*#__PURE__*/_regenerator["default"].mark(function _callee14(channelName, time, token, writerUuid) {
505505
var fileName;
506506
return _regenerator["default"].wrap(function _callee14$(_context14) {
507507
while (1) switch (_context14.prev = _context14.next) {
@@ -520,7 +520,7 @@ function getAllMessages(_x16, _x17) {
520520
return _getAllMessages.apply(this, arguments);
521521
}
522522
function _getAllMessages() {
523-
_getAllMessages = (0, _asyncToGenerator2["default"])( /*#__PURE__*/_regenerator["default"].mark(function _callee15(channelName, paths) {
523+
_getAllMessages = (0, _asyncToGenerator2["default"])(/*#__PURE__*/_regenerator["default"].mark(function _callee15(channelName, paths) {
524524
var messagesPath, files;
525525
return _regenerator["default"].wrap(function _callee15$(_context15) {
526526
while (1) switch (_context15.prev = _context15.next) {
@@ -567,7 +567,7 @@ function cleanOldMessages(_x18, _x19) {
567567
return _cleanOldMessages.apply(this, arguments);
568568
}
569569
function _cleanOldMessages() {
570-
_cleanOldMessages = (0, _asyncToGenerator2["default"])( /*#__PURE__*/_regenerator["default"].mark(function _callee16(messageObjects, ttl) {
570+
_cleanOldMessages = (0, _asyncToGenerator2["default"])(/*#__PURE__*/_regenerator["default"].mark(function _callee16(messageObjects, ttl) {
571571
var olderThan;
572572
return _regenerator["default"].wrap(function _callee16$(_context16) {
573573
while (1) switch (_context16.prev = _context16.next) {
@@ -599,7 +599,7 @@ function create(_x20) {
599599
return _create.apply(this, arguments);
600600
}
601601
function _create() {
602-
_create = (0, _asyncToGenerator2["default"])( /*#__PURE__*/_regenerator["default"].mark(function _callee17(channelName) {
602+
_create = (0, _asyncToGenerator2["default"])(/*#__PURE__*/_regenerator["default"].mark(function _callee17(channelName) {
603603
var options,
604604
time,
605605
paths,
@@ -708,7 +708,7 @@ function handleMessagePing(_x21, _x22) {
708708
* @return {Promise<void>}
709709
*/
710710
function _handleMessagePing() {
711-
_handleMessagePing = (0, _asyncToGenerator2["default"])( /*#__PURE__*/_regenerator["default"].mark(function _callee18(state, msgObj) {
711+
_handleMessagePing = (0, _asyncToGenerator2["default"])(/*#__PURE__*/_regenerator["default"].mark(function _callee18(state, msgObj) {
712712
var messages, useMessages;
713713
return _regenerator["default"].wrap(function _callee18$(_context18) {
714714
while (1) switch (_context18.prev = _context18.next) {
@@ -772,8 +772,8 @@ function refreshReaderClients(channelState) {
772772
// remove subscriptions to closed readers
773773
Object.keys(channelState.otherReaderClients).filter(function (readerUuid) {
774774
return !otherReaders.includes(readerUuid);
775-
}).forEach( /*#__PURE__*/function () {
776-
var _ref2 = (0, _asyncToGenerator2["default"])( /*#__PURE__*/_regenerator["default"].mark(function _callee2(readerUuid) {
775+
}).forEach(/*#__PURE__*/function () {
776+
var _ref2 = (0, _asyncToGenerator2["default"])(/*#__PURE__*/_regenerator["default"].mark(function _callee2(readerUuid) {
777777
return _regenerator["default"].wrap(function _callee2$(_context2) {
778778
while (1) switch (_context2.prev = _context2.next) {
779779
case 0:
@@ -806,8 +806,8 @@ function refreshReaderClients(channelState) {
806806
.filter(function (readerUuid) {
807807
return !channelState.otherReaderClients[readerUuid];
808808
}) // not already has client
809-
.map( /*#__PURE__*/function () {
810-
var _ref3 = (0, _asyncToGenerator2["default"])( /*#__PURE__*/_regenerator["default"].mark(function _callee3(readerUuid) {
809+
.map(/*#__PURE__*/function () {
810+
var _ref3 = (0, _asyncToGenerator2["default"])(/*#__PURE__*/_regenerator["default"].mark(function _callee3(readerUuid) {
811811
var client;
812812
return _regenerator["default"].wrap(function _callee3$(_context3) {
813813
while (1) switch (_context3.prev = _context3.next) {
@@ -863,15 +863,15 @@ function postMessage(_x25, _x26) {
863863
* but will speed up things when this module is used in unit-tests.
864864
*/
865865
function _postMessage() {
866-
_postMessage = (0, _asyncToGenerator2["default"])( /*#__PURE__*/_regenerator["default"].mark(function _callee20(channelState, messageJson) {
866+
_postMessage = (0, _asyncToGenerator2["default"])(/*#__PURE__*/_regenerator["default"].mark(function _callee20(channelState, messageJson) {
867867
var writePromise;
868868
return _regenerator["default"].wrap(function _callee20$(_context20) {
869869
while (1) switch (_context20.prev = _context20.next) {
870870
case 0:
871871
writePromise = channelState.writeFileQueue.add(function () {
872872
return writeMessage(channelState.channelName, channelState.uuid, messageJson, channelState.paths);
873873
});
874-
channelState.writeBlockPromise = channelState.writeBlockPromise.then( /*#__PURE__*/(0, _asyncToGenerator2["default"])( /*#__PURE__*/_regenerator["default"].mark(function _callee19() {
874+
channelState.writeBlockPromise = channelState.writeBlockPromise.then(/*#__PURE__*/(0, _asyncToGenerator2["default"])(/*#__PURE__*/_regenerator["default"].mark(function _callee19() {
875875
var _yield$Promise$all2, msgObj, pingStr, writeToReadersPromise;
876876
return _regenerator["default"].wrap(function _callee19$(_context19) {
877877
while (1) switch (_context19.prev = _context19.next) {

‎dist/esbrowser/leader-election-util.js‎

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -36,7 +36,6 @@ export function beLeader(leaderElector) {
3636
sendLeaderMessage(leaderElector, 'tell'); // ensure other leader also knows the problem
3737
}
3838
};
39-
4039
leaderElector.broadcastChannel.addEventListener('internal', isLeaderListener);
4140
leaderElector._lstns.push(isLeaderListener);
4241
return sendLeaderMessage(leaderElector, 'tell');

‎dist/esbrowser/leader-election.js‎

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -168,7 +168,7 @@ LeaderElection.prototype = {
168168
});
169169
},
170170
awaitLeadership: function awaitLeadership() {
171-
if ( /* _awaitLeadershipPromise */
171+
if (/* _awaitLeadershipPromise */
172172
!this._aLP) {
173173
this._aLP = _awaitLeadershipOnce(this);
174174
}
@@ -225,7 +225,7 @@ function _awaitLeadershipOnce(leaderElector) {
225225
* Try on fallbackInterval
226226
* @recursive
227227
*/
228-
var tryOnFallBack = function tryOnFallBack() {
228+
var _tryOnFallBack = function tryOnFallBack() {
229229
return sleep(leaderElector._options.fallbackInterval).then(function () {
230230
if (leaderElector.isDead || resolved) {
231231
return;
@@ -237,13 +237,13 @@ function _awaitLeadershipOnce(leaderElector) {
237237
if (leaderElector.isLeader) {
238238
finish();
239239
} else {
240-
tryOnFallBack();
240+
_tryOnFallBack();
241241
}
242242
});
243243
}
244244
});
245245
};
246-
tryOnFallBack();
246+
_tryOnFallBack();
247247

248248
// try when other leader dies
249249
var whenDeathListener = function whenDeathListener(msg) {

‎dist/esbrowser/methods/localstorage.js‎

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -96,7 +96,6 @@ export function create(channelName, options) {
9696
uuid: uuid,
9797
eMIs: eMIs // emittedMessagesIds
9898
};
99-
10099
state.listener = addStorageEventListener(channelName, function (msgObj) {
101100
if (!state.messagesCallback) return; // no listener
102101
if (msgObj.uuid === uuid) return; // own message

‎dist/esbrowser/methods/native.js‎

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -8,7 +8,6 @@ export function create(channelName) {
88
bc: new BroadcastChannel(channelName),
99
subFns: [] // subscriberFunctions
1010
};
11-
1211
state.bc.onmessage = function (msgEvent) {
1312
if (state.messagesCallback) {
1413
state.messagesCallback(msgEvent.data);

0 commit comments

Comments
 (0)