Socket
Socket
Sign inDemoInstall

amelisa

Package Overview
Dependencies
Maintainers
1
Versions
32
Alerts
File Explorer

Advanced tools

Socket logo

Install Socket

Detect and block malicious and high-risk dependencies

Install

amelisa - npm Package Compare versions

Comparing version 0.1.28 to 0.1.33

16

lib/client/ClientQuery.js

@@ -80,3 +80,3 @@ 'use strict';

value: function () {
var ref = (0, _asyncToGenerator3.default)(_regenerator2.default.mark(function _callee() {
var _ref = (0, _asyncToGenerator3.default)(_regenerator2.default.mark(function _callee() {
return _regenerator2.default.wrap(function _callee$(_context) {

@@ -97,3 +97,3 @@ while (1) {

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

@@ -106,3 +106,3 @@

value: function () {
var ref = (0, _asyncToGenerator3.default)(_regenerator2.default.mark(function _callee2() {
var _ref2 = (0, _asyncToGenerator3.default)(_regenerator2.default.mark(function _callee2() {
return _regenerator2.default.wrap(function _callee2$(_context2) {

@@ -124,3 +124,3 @@ while (1) {

function subscribe() {
return ref.apply(this, arguments);
return _ref2.apply(this, arguments);
}

@@ -133,3 +133,3 @@

value: function () {
var ref = (0, _asyncToGenerator3.default)(_regenerator2.default.mark(function _callee3() {
var _ref3 = (0, _asyncToGenerator3.default)(_regenerator2.default.mark(function _callee3() {
return _regenerator2.default.wrap(function _callee3$(_context3) {

@@ -150,3 +150,3 @@ while (1) {

function unsubscribe() {
return ref.apply(this, arguments);
return _ref3.apply(this, arguments);
}

@@ -159,3 +159,3 @@

value: function () {
var ref = (0, _asyncToGenerator3.default)(_regenerator2.default.mark(function _callee4() {
var _ref4 = (0, _asyncToGenerator3.default)(_regenerator2.default.mark(function _callee4() {
return _regenerator2.default.wrap(function _callee4$(_context4) {

@@ -180,3 +180,3 @@ while (1) {

function fetchAndGet() {
return ref.apply(this, arguments);
return _ref4.apply(this, arguments);
}

@@ -183,0 +183,0 @@

@@ -67,2 +67,4 @@ 'use strict';

if (this.queryDatas && this.queryDatas[hash]) query.data = this.queryDatas[hash];
this.data[hash] = query;

@@ -128,2 +130,19 @@ }

value: function isQuery(collectionName, expression) {}
}, {
key: 'bundle',
value: function bundle() {
var data = {};
for (var hash in this.data) {
var query = this.data[hash];
data[hash] = query.get();
}
return data;
}
}, {
key: 'unbundle',
value: function unbundle(data) {
this.queryDatas = data;
}
}]);

@@ -130,0 +149,0 @@ return ClientQuerySet;

@@ -148,3 +148,3 @@ 'use strict';

value: function () {
var ref = (0, _asyncToGenerator3.default)(_regenerator2.default.mark(function _callee() {
var _ref = (0, _asyncToGenerator3.default)(_regenerator2.default.mark(function _callee() {
var _this2 = this;

@@ -202,3 +202,3 @@

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

@@ -205,0 +205,0 @@

@@ -111,3 +111,3 @@ 'use strict';

value: function () {
var ref = (0, _asyncToGenerator3.default)(_regenerator2.default.mark(function _callee() {
var _ref = (0, _asyncToGenerator3.default)(_regenerator2.default.mark(function _callee() {
var collectionNames, _iteratorNormalCompletion, _didIteratorError, _iteratorError, _iterator, _step, collectionName, collection;

@@ -206,3 +206,3 @@

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

@@ -215,3 +215,3 @@

value: function () {
var ref = (0, _asyncToGenerator3.default)(_regenerator2.default.mark(function _callee2() {
var _ref2 = (0, _asyncToGenerator3.default)(_regenerator2.default.mark(function _callee2() {
var collectionNames, _iteratorNormalCompletion2, _didIteratorError2, _iteratorError2, _iterator2, _step2, collectionName, collection;

@@ -301,3 +301,3 @@

function fillFromClientStorage() {
return ref.apply(this, arguments);
return _ref2.apply(this, arguments);
}

@@ -304,0 +304,0 @@

@@ -60,3 +60,3 @@ 'use strict';

value: function () {
var ref = (0, _asyncToGenerator3.default)(_regenerator2.default.mark(function _callee(docId, docData) {
var _ref = (0, _asyncToGenerator3.default)(_regenerator2.default.mark(function _callee(docId, docData) {
return _regenerator2.default.wrap(function _callee$(_context) {

@@ -77,3 +77,3 @@ while (1) {

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

@@ -80,0 +80,0 @@

@@ -7,2 +7,10 @@ 'use strict';

var _regenerator = require('babel-runtime/regenerator');
var _regenerator2 = _interopRequireDefault(_regenerator);
var _asyncToGenerator2 = require('babel-runtime/helpers/asyncToGenerator');
var _asyncToGenerator3 = _interopRequireDefault(_asyncToGenerator2);
var _getPrototypeOf = require('babel-runtime/core-js/object/get-prototype-of');

@@ -16,2 +24,6 @@

var _createClass2 = require('babel-runtime/helpers/createClass');
var _createClass3 = _interopRequireDefault(_createClass2);
var _possibleConstructorReturn2 = require('babel-runtime/helpers/possibleConstructorReturn');

@@ -39,2 +51,24 @@

(0, _createClass3.default)(LocalDoc, [{
key: 'send',
value: function () {
var _ref = (0, _asyncToGenerator3.default)(_regenerator2.default.mark(function _callee() {
return _regenerator2.default.wrap(function _callee$(_context) {
while (1) {
switch (_context.prev = _context.next) {
case 0:
case 'end':
return _context.stop();
}
}
}, _callee, this);
}));
function send() {
return _ref.apply(this, arguments);
}
return send;
}()
}]);
return LocalDoc;

@@ -41,0 +75,0 @@ }(_MutableDoc3.default);

@@ -160,3 +160,3 @@ 'use strict';

value: function () {
var ref = (0, _asyncToGenerator3.default)(_regenerator2.default.mark(function _callee() {
var _ref = (0, _asyncToGenerator3.default)(_regenerator2.default.mark(function _callee() {
var source;

@@ -209,3 +209,3 @@ return _regenerator2.default.wrap(function _callee$(_context) {

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

@@ -218,4 +218,4 @@

value: function () {
var ref = (0, _asyncToGenerator3.default)(_regenerator2.default.mark(function _callee2() {
var start, op, _ref, collectionNames, date, projectionHashes, version, source;
var _ref2 = (0, _asyncToGenerator3.default)(_regenerator2.default.mark(function _callee2() {
var start, op, _ref3, collectionNames, date, projectionHashes, version, source;

@@ -237,7 +237,7 @@ return _regenerator2.default.wrap(function _callee2$(_context2) {

case 5:
_ref = _context2.sent;
collectionNames = _ref.collectionNames;
date = _ref.date;
projectionHashes = _ref.projectionHashes;
version = _ref.version;
_ref3 = _context2.sent;
collectionNames = _ref3.collectionNames;
date = _ref3.date;
projectionHashes = _ref3.projectionHashes;
version = _ref3.version;

@@ -311,3 +311,3 @@ this.syncDate(start, date);

function handshake() {
return ref.apply(this, arguments);
return _ref2.apply(this, arguments);
}

@@ -320,3 +320,3 @@

value: function () {
var ref = (0, _asyncToGenerator3.default)(_regenerator2.default.mark(function _callee3() {
var _ref4 = (0, _asyncToGenerator3.default)(_regenerator2.default.mark(function _callee3() {
var _this2 = this;

@@ -351,3 +351,3 @@

function onReady() {
return ref.apply(this, arguments);
return _ref4.apply(this, arguments);
}

@@ -360,3 +360,3 @@

value: function () {
var ref = (0, _asyncToGenerator3.default)(_regenerator2.default.mark(function _callee4() {
var _ref5 = (0, _asyncToGenerator3.default)(_regenerator2.default.mark(function _callee4() {
for (var _len = arguments.length, rawSubscribes = Array(_len), _key = 0; _key < _len; _key++) {

@@ -387,3 +387,3 @@ rawSubscribes[_key] = arguments[_key];

function fetch(_x2) {
return ref.apply(this, arguments);
return _ref5.apply(this, arguments);
}

@@ -396,3 +396,3 @@

value: function () {
var ref = (0, _asyncToGenerator3.default)(_regenerator2.default.mark(function _callee5() {
var _ref6 = (0, _asyncToGenerator3.default)(_regenerator2.default.mark(function _callee5() {
for (var _len2 = arguments.length, rawSubscribes = Array(_len2), _key2 = 0; _key2 < _len2; _key2++) {

@@ -431,3 +431,3 @@ rawSubscribes[_key2] = arguments[_key2];

function subscribe(_x3) {
return ref.apply(this, arguments);
return _ref6.apply(this, arguments);
}

@@ -440,3 +440,3 @@

value: function () {
var ref = (0, _asyncToGenerator3.default)(_regenerator2.default.mark(function _callee6(collectionName, docIdOrExpression) {
var _ref7 = (0, _asyncToGenerator3.default)(_regenerator2.default.mark(function _callee6(collectionName, docIdOrExpression) {
return _regenerator2.default.wrap(function _callee6$(_context6) {

@@ -465,3 +465,3 @@ while (1) {

function fetchAndGet(_x4, _x5) {
return ref.apply(this, arguments);
return _ref7.apply(this, arguments);
}

@@ -480,3 +480,3 @@

value: function () {
var ref = (0, _asyncToGenerator3.default)(_regenerator2.default.mark(function _callee7() {
var _ref8 = (0, _asyncToGenerator3.default)(_regenerator2.default.mark(function _callee7() {
return _regenerator2.default.wrap(function _callee7$(_context7) {

@@ -500,3 +500,3 @@ while (1) {

function setOnline() {
return ref.apply(this, arguments);
return _ref8.apply(this, arguments);
}

@@ -516,3 +516,3 @@

value: function () {
var ref = (0, _asyncToGenerator3.default)(_regenerator2.default.mark(function _callee8(message) {
var _ref9 = (0, _asyncToGenerator3.default)(_regenerator2.default.mark(function _callee8(message) {
var type, collectionName, docId, expression, value, version, diffs, docOps, ops, ackId, error, doc, query, collection, callbacks, _iteratorNormalCompletion, _didIteratorError, _iteratorError, _iterator, _step, callback;

@@ -655,3 +655,3 @@

function onMessage(_x6) {
return ref.apply(this, arguments);
return _ref9.apply(this, arguments);
}

@@ -681,3 +681,3 @@

value: function () {
var ref = (0, _asyncToGenerator3.default)(_regenerator2.default.mark(function _callee9(collectionName, docData) {
var _ref10 = (0, _asyncToGenerator3.default)(_regenerator2.default.mark(function _callee9(collectionName, docData) {
var docId, collection;

@@ -708,3 +708,3 @@ return _regenerator2.default.wrap(function _callee9$(_context9) {

function add(_x7, _x8) {
return ref.apply(this, arguments);
return _ref10.apply(this, arguments);
}

@@ -717,3 +717,3 @@

value: function () {
var ref = (0, _asyncToGenerator3.default)(_regenerator2.default.mark(function _callee10(path, value) {
var _ref11 = (0, _asyncToGenerator3.default)(_regenerator2.default.mark(function _callee10(path, value) {
var _parsePath, _parsePath2, collectionName, docId, field, doc;

@@ -748,3 +748,3 @@

function set(_x9, _x10) {
return ref.apply(this, arguments);
return _ref11.apply(this, arguments);
}

@@ -757,3 +757,3 @@

value: function () {
var ref = (0, _asyncToGenerator3.default)(_regenerator2.default.mark(function _callee11(path, value) {
var _ref12 = (0, _asyncToGenerator3.default)(_regenerator2.default.mark(function _callee11(path, value) {
var _parsePath3, _parsePath4, collectionName, docId, field, doc;

@@ -788,3 +788,3 @@

function setNull(_x11, _x12) {
return ref.apply(this, arguments);
return _ref12.apply(this, arguments);
}

@@ -797,3 +797,3 @@

value: function () {
var ref = (0, _asyncToGenerator3.default)(_regenerator2.default.mark(function _callee12(path, value) {
var _ref13 = (0, _asyncToGenerator3.default)(_regenerator2.default.mark(function _callee12(path, value) {
var _parsePath5, _parsePath6, collectionName, docId, field, doc;

@@ -828,3 +828,3 @@

function setDiff(_x13, _x14) {
return ref.apply(this, arguments);
return _ref13.apply(this, arguments);
}

@@ -837,3 +837,3 @@

value: function () {
var ref = (0, _asyncToGenerator3.default)(_regenerator2.default.mark(function _callee13() {
var _ref14 = (0, _asyncToGenerator3.default)(_regenerator2.default.mark(function _callee13() {
for (var _len4 = arguments.length, path = Array(_len4), _key4 = 0; _key4 < _len4; _key4++) {

@@ -872,3 +872,3 @@ path[_key4] = arguments[_key4];

function del(_x15) {
return ref.apply(this, arguments);
return _ref14.apply(this, arguments);
}

@@ -881,3 +881,3 @@

value: function () {
var ref = (0, _asyncToGenerator3.default)(_regenerator2.default.mark(function _callee14(path, value) {
var _ref15 = (0, _asyncToGenerator3.default)(_regenerator2.default.mark(function _callee14(path, value) {
var _parsePath9, _parsePath10, collectionName, docId, field, doc;

@@ -912,3 +912,3 @@

function push(_x16, _x17) {
return ref.apply(this, arguments);
return _ref15.apply(this, arguments);
}

@@ -921,3 +921,3 @@

value: function () {
var ref = (0, _asyncToGenerator3.default)(_regenerator2.default.mark(function _callee15(path, value) {
var _ref16 = (0, _asyncToGenerator3.default)(_regenerator2.default.mark(function _callee15(path, value) {
var _parsePath11, _parsePath12, collectionName, docId, field, doc;

@@ -952,3 +952,3 @@

function unshift(_x18, _x19) {
return ref.apply(this, arguments);
return _ref16.apply(this, arguments);
}

@@ -961,3 +961,3 @@

value: function () {
var ref = (0, _asyncToGenerator3.default)(_regenerator2.default.mark(function _callee16(path) {
var _ref17 = (0, _asyncToGenerator3.default)(_regenerator2.default.mark(function _callee16(path) {
var _parsePath13, _parsePath14, collectionName, docId, field, doc;

@@ -992,3 +992,3 @@

function pop(_x20) {
return ref.apply(this, arguments);
return _ref17.apply(this, arguments);
}

@@ -1001,3 +1001,3 @@

value: function () {
var ref = (0, _asyncToGenerator3.default)(_regenerator2.default.mark(function _callee17(path) {
var _ref18 = (0, _asyncToGenerator3.default)(_regenerator2.default.mark(function _callee17(path) {
var _parsePath15, _parsePath16, collectionName, docId, field, doc;

@@ -1032,3 +1032,3 @@

function shift(_x21) {
return ref.apply(this, arguments);
return _ref18.apply(this, arguments);
}

@@ -1041,3 +1041,3 @@

value: function () {
var ref = (0, _asyncToGenerator3.default)(_regenerator2.default.mark(function _callee18(path, index, values) {
var _ref19 = (0, _asyncToGenerator3.default)(_regenerator2.default.mark(function _callee18(path, index, values) {
var _parsePath17, _parsePath18, collectionName, docId, field, doc;

@@ -1073,3 +1073,3 @@

function insert(_x22, _x23, _x24) {
return ref.apply(this, arguments);
return _ref19.apply(this, arguments);
}

@@ -1082,3 +1082,3 @@

value: function () {
var ref = (0, _asyncToGenerator3.default)(_regenerator2.default.mark(function _callee19(path, index, howMany) {
var _ref20 = (0, _asyncToGenerator3.default)(_regenerator2.default.mark(function _callee19(path, index, howMany) {
var _parsePath19, _parsePath20, collectionName, docId, field, doc;

@@ -1115,3 +1115,3 @@

function remove(_x25, _x26, _x27) {
return ref.apply(this, arguments);
return _ref20.apply(this, arguments);
}

@@ -1124,3 +1124,3 @@

value: function () {
var ref = (0, _asyncToGenerator3.default)(_regenerator2.default.mark(function _callee20(path, from, to, howMany) {
var _ref21 = (0, _asyncToGenerator3.default)(_regenerator2.default.mark(function _callee20(path, from, to, howMany) {
var _parsePath21, _parsePath22, collectionName, docId, field, doc;

@@ -1158,3 +1158,3 @@

function move(_x28, _x29, _x30, _x31) {
return ref.apply(this, arguments);
return _ref21.apply(this, arguments);
}

@@ -1167,3 +1167,3 @@

value: function () {
var ref = (0, _asyncToGenerator3.default)(_regenerator2.default.mark(function _callee21(path, from, to) {
var _ref22 = (0, _asyncToGenerator3.default)(_regenerator2.default.mark(function _callee21(path, from, to) {
var _parsePath23, _parsePath24, collectionName, docId, field, doc;

@@ -1200,3 +1200,3 @@

function swap(_x32, _x33, _x34) {
return ref.apply(this, arguments);
return _ref22.apply(this, arguments);
}

@@ -1209,3 +1209,3 @@

value: function () {
var ref = (0, _asyncToGenerator3.default)(_regenerator2.default.mark(function _callee22(path, value) {
var _ref23 = (0, _asyncToGenerator3.default)(_regenerator2.default.mark(function _callee22(path, value) {
var _parsePath25, _parsePath26, collectionName, docId, field, doc;

@@ -1241,3 +1241,3 @@

function arrayDiff(_x35, _x36) {
return ref.apply(this, arguments);
return _ref23.apply(this, arguments);
}

@@ -1250,3 +1250,3 @@

value: function () {
var ref = (0, _asyncToGenerator3.default)(_regenerator2.default.mark(function _callee23(path) {
var _ref24 = (0, _asyncToGenerator3.default)(_regenerator2.default.mark(function _callee23(path) {
var _parsePath27, _parsePath28, collectionName, docId, field, doc;

@@ -1281,3 +1281,3 @@

function invert(_x37) {
return ref.apply(this, arguments);
return _ref24.apply(this, arguments);
}

@@ -1290,3 +1290,3 @@

value: function () {
var ref = (0, _asyncToGenerator3.default)(_regenerator2.default.mark(function _callee24(path, value) {
var _ref25 = (0, _asyncToGenerator3.default)(_regenerator2.default.mark(function _callee24(path, value) {
var _parsePath29, _parsePath30, collectionName, docId, field, doc;

@@ -1322,3 +1322,3 @@

function increment(_x38, _x39) {
return ref.apply(this, arguments);
return _ref25.apply(this, arguments);
}

@@ -1331,3 +1331,3 @@

value: function () {
var ref = (0, _asyncToGenerator3.default)(_regenerator2.default.mark(function _callee25(path, index, value) {
var _ref26 = (0, _asyncToGenerator3.default)(_regenerator2.default.mark(function _callee25(path, index, value) {
var _parsePath31, _parsePath32, collectionName, docId, field, doc;

@@ -1364,3 +1364,3 @@

function stringInsert(_x40, _x41, _x42) {
return ref.apply(this, arguments);
return _ref26.apply(this, arguments);
}

@@ -1373,3 +1373,3 @@

value: function () {
var ref = (0, _asyncToGenerator3.default)(_regenerator2.default.mark(function _callee26(path, index, howMany) {
var _ref27 = (0, _asyncToGenerator3.default)(_regenerator2.default.mark(function _callee26(path, index, howMany) {
var _parsePath33, _parsePath34, collectionName, docId, field, doc;

@@ -1406,3 +1406,3 @@

function stringRemove(_x43, _x44, _x45) {
return ref.apply(this, arguments);
return _ref27.apply(this, arguments);
}

@@ -1415,3 +1415,3 @@

value: function () {
var ref = (0, _asyncToGenerator3.default)(_regenerator2.default.mark(function _callee27(path, value) {
var _ref28 = (0, _asyncToGenerator3.default)(_regenerator2.default.mark(function _callee27(path, value) {
var _parsePath35, _parsePath36, collectionName, docId, field, doc;

@@ -1447,3 +1447,3 @@

function stringDiff(_x46, _x47) {
return ref.apply(this, arguments);
return _ref28.apply(this, arguments);
}

@@ -1456,3 +1456,3 @@

value: function () {
var ref = (0, _asyncToGenerator3.default)(_regenerator2.default.mark(function _callee28(path, value) {
var _ref29 = (0, _asyncToGenerator3.default)(_regenerator2.default.mark(function _callee28(path, value) {
var _parsePath37, _parsePath38, collectionName, docId, field, doc;

@@ -1488,3 +1488,3 @@

function rich(_x48, _x49) {
return ref.apply(this, arguments);
return _ref29.apply(this, arguments);
}

@@ -1497,3 +1497,3 @@

value: function () {
var ref = (0, _asyncToGenerator3.default)(_regenerator2.default.mark(function _callee29(path, value) {
var _ref30 = (0, _asyncToGenerator3.default)(_regenerator2.default.mark(function _callee29(path, value) {
var _parsePath39, _parsePath40, collectionName, docId, field, doc;

@@ -1529,3 +1529,3 @@

function draftDiff(_x50, _x51) {
return ref.apply(this, arguments);
return _ref30.apply(this, arguments);
}

@@ -1548,3 +1548,3 @@

value: function () {
var ref = (0, _asyncToGenerator3.default)(_regenerator2.default.mark(function _callee30(newProjectionHashes) {
var _ref31 = (0, _asyncToGenerator3.default)(_regenerator2.default.mark(function _callee30(newProjectionHashes) {
var _this3 = this;

@@ -1581,3 +1581,3 @@

function onProjections(_x52) {
return ref.apply(this, arguments);
return _ref31.apply(this, arguments);
}

@@ -1608,3 +1608,3 @@

value: function () {
var ref = (0, _asyncToGenerator3.default)(_regenerator2.default.mark(function _callee31(message, forceSend) {
var _ref32 = (0, _asyncToGenerator3.default)(_regenerator2.default.mark(function _callee31(message, forceSend) {
var _this4 = this;

@@ -1652,3 +1652,3 @@

function send(_x53, _x54) {
return ref.apply(this, arguments);
return _ref32.apply(this, arguments);
}

@@ -1676,3 +1676,3 @@

value: function () {
var ref = (0, _asyncToGenerator3.default)(_regenerator2.default.mark(function _callee32(opData) {
var _ref33 = (0, _asyncToGenerator3.default)(_regenerator2.default.mark(function _callee32(opData) {
var op;

@@ -1695,3 +1695,3 @@ return _regenerator2.default.wrap(function _callee32$(_context32) {

function sendOp(_x55) {
return ref.apply(this, arguments);
return _ref33.apply(this, arguments);
}

@@ -1737,3 +1737,3 @@

value: function bundleJsonFromDom() {
if (!this.getBundleJsonFromDom) return (0, _stringify2.default)({ collections: {} });
if (!this.getBundleJsonFromDom) return (0, _stringify2.default)({ collections: {}, queries: {} });

@@ -1744,3 +1744,3 @@ try {

console.error('Error while reading bundle from dom', err);
return (0, _stringify2.default)({ collections: {} });
return (0, _stringify2.default)({ collections: {}, queries: {} });
}

@@ -1754,3 +1754,4 @@ }

var bundle = {
collections: this.collectionSet.bundle()
collections: this.collectionSet.bundle(),
queries: this.querySet.bundle()
};

@@ -1765,3 +1766,3 @@

value: function () {
var ref = (0, _asyncToGenerator3.default)(_regenerator2.default.mark(function _callee33() {
var _ref34 = (0, _asyncToGenerator3.default)(_regenerator2.default.mark(function _callee33() {
var json, bundle;

@@ -1793,4 +1794,5 @@ return _regenerator2.default.wrap(function _callee33$(_context33) {

this.collectionSet.unbundle(bundle.collections);
this.querySet.unbundle(bundle.queries);
case 8:
case 9:
case 'end':

@@ -1804,3 +1806,3 @@ return _context33.stop();

function unbundleData() {
return ref.apply(this, arguments);
return _ref34.apply(this, arguments);
}

@@ -1807,0 +1809,0 @@

@@ -77,3 +77,3 @@ 'use strict';

value: function () {
var ref = (0, _asyncToGenerator3.default)(_regenerator2.default.mark(function _callee() {
var _ref = (0, _asyncToGenerator3.default)(_regenerator2.default.mark(function _callee() {
return _regenerator2.default.wrap(function _callee$(_context) {

@@ -91,3 +91,3 @@ while (1) {

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

@@ -100,3 +100,3 @@

value: function () {
var ref = (0, _asyncToGenerator3.default)(_regenerator2.default.mark(function _callee2() {
var _ref2 = (0, _asyncToGenerator3.default)(_regenerator2.default.mark(function _callee2() {
return _regenerator2.default.wrap(function _callee2$(_context2) {

@@ -114,3 +114,3 @@ while (1) {

function subscribe() {
return ref.apply(this, arguments);
return _ref2.apply(this, arguments);
}

@@ -123,3 +123,3 @@

value: function () {
var ref = (0, _asyncToGenerator3.default)(_regenerator2.default.mark(function _callee3() {
var _ref3 = (0, _asyncToGenerator3.default)(_regenerator2.default.mark(function _callee3() {
return _regenerator2.default.wrap(function _callee3$(_context3) {

@@ -137,3 +137,3 @@ while (1) {

function unsubscribe() {
return ref.apply(this, arguments);
return _ref3.apply(this, arguments);
}

@@ -146,3 +146,3 @@

value: function () {
var ref = (0, _asyncToGenerator3.default)(_regenerator2.default.mark(function _callee4() {
var _ref4 = (0, _asyncToGenerator3.default)(_regenerator2.default.mark(function _callee4() {
return _regenerator2.default.wrap(function _callee4$(_context4) {

@@ -167,3 +167,3 @@ while (1) {

function fetchAndGet() {
return ref.apply(this, arguments);
return _ref4.apply(this, arguments);
}

@@ -222,3 +222,3 @@

value: function () {
var ref = (0, _asyncToGenerator3.default)(_regenerator2.default.mark(function _callee5(field, value) {
var _ref5 = (0, _asyncToGenerator3.default)(_regenerator2.default.mark(function _callee5(field, value) {
var op;

@@ -249,3 +249,3 @@ return _regenerator2.default.wrap(function _callee5$(_context5) {

function set(_x, _x2) {
return ref.apply(this, arguments);
return _ref5.apply(this, arguments);
}

@@ -258,3 +258,3 @@

value: function () {
var ref = (0, _asyncToGenerator3.default)(_regenerator2.default.mark(function _callee6(field, value) {
var _ref6 = (0, _asyncToGenerator3.default)(_regenerator2.default.mark(function _callee6(field, value) {
var arraysField, previous;

@@ -287,3 +287,3 @@ return _regenerator2.default.wrap(function _callee6$(_context6) {

function setNull(_x3, _x4) {
return ref.apply(this, arguments);
return _ref6.apply(this, arguments);
}

@@ -296,3 +296,3 @@

value: function () {
var ref = (0, _asyncToGenerator3.default)(_regenerator2.default.mark(function _callee7(field, value) {
var _ref7 = (0, _asyncToGenerator3.default)(_regenerator2.default.mark(function _callee7(field, value) {
var arraysField, previous;

@@ -325,3 +325,3 @@ return _regenerator2.default.wrap(function _callee7$(_context7) {

function setDiff(_x5, _x6) {
return ref.apply(this, arguments);
return _ref7.apply(this, arguments);
}

@@ -334,3 +334,3 @@

value: function () {
var ref = (0, _asyncToGenerator3.default)(_regenerator2.default.mark(function _callee8(field) {
var _ref8 = (0, _asyncToGenerator3.default)(_regenerator2.default.mark(function _callee8(field) {
var op;

@@ -363,3 +363,3 @@ return _regenerator2.default.wrap(function _callee8$(_context8) {

function del(_x7) {
return ref.apply(this, arguments);
return _ref8.apply(this, arguments);
}

@@ -372,3 +372,3 @@

value: function () {
var ref = (0, _asyncToGenerator3.default)(_regenerator2.default.mark(function _callee9(field, value) {
var _ref9 = (0, _asyncToGenerator3.default)(_regenerator2.default.mark(function _callee9(field, value) {
var itemId, op;

@@ -402,3 +402,3 @@ return _regenerator2.default.wrap(function _callee9$(_context9) {

function push(_x8, _x9) {
return ref.apply(this, arguments);
return _ref9.apply(this, arguments);
}

@@ -411,3 +411,3 @@

value: function () {
var ref = (0, _asyncToGenerator3.default)(_regenerator2.default.mark(function _callee10(field, value) {
var _ref10 = (0, _asyncToGenerator3.default)(_regenerator2.default.mark(function _callee10(field, value) {
var itemId, op;

@@ -441,3 +441,3 @@ return _regenerator2.default.wrap(function _callee10$(_context10) {

function unshift(_x10, _x11) {
return ref.apply(this, arguments);
return _ref10.apply(this, arguments);
}

@@ -450,3 +450,3 @@

value: function () {
var ref = (0, _asyncToGenerator3.default)(_regenerator2.default.mark(function _callee11(field) {
var _ref11 = (0, _asyncToGenerator3.default)(_regenerator2.default.mark(function _callee11(field) {
var op;

@@ -477,3 +477,3 @@ return _regenerator2.default.wrap(function _callee11$(_context11) {

function pop(_x12) {
return ref.apply(this, arguments);
return _ref11.apply(this, arguments);
}

@@ -486,3 +486,3 @@

value: function () {
var ref = (0, _asyncToGenerator3.default)(_regenerator2.default.mark(function _callee12(field) {
var _ref12 = (0, _asyncToGenerator3.default)(_regenerator2.default.mark(function _callee12(field) {
var op;

@@ -513,3 +513,3 @@ return _regenerator2.default.wrap(function _callee12$(_context12) {

function shift(_x13) {
return ref.apply(this, arguments);
return _ref12.apply(this, arguments);
}

@@ -522,3 +522,3 @@

value: function () {
var ref = (0, _asyncToGenerator3.default)(_regenerator2.default.mark(function _callee13(field, index, values) {
var _ref13 = (0, _asyncToGenerator3.default)(_regenerator2.default.mark(function _callee13(field, index, values) {
var array, positionId, ops, type, _iteratorNormalCompletion2, _didIteratorError2, _iteratorError2, _iterator2, _step2, value, itemId, _op, op;

@@ -611,3 +611,3 @@

});
return _context13.abrupt('return', this.model.send(op));
return _context13.abrupt('return', this.send(op));

@@ -623,3 +623,3 @@ case 32:

function insert(_x14, _x15, _x16) {
return ref.apply(this, arguments);
return _ref13.apply(this, arguments);
}

@@ -632,3 +632,3 @@

value: function () {
var ref = (0, _asyncToGenerator3.default)(_regenerator2.default.mark(function _callee14(field, index) {
var _ref14 = (0, _asyncToGenerator3.default)(_regenerator2.default.mark(function _callee14(field, index) {
var howMany = arguments.length <= 2 || arguments[2] === undefined ? 1 : arguments[2];

@@ -691,3 +691,3 @@

});
return _context14.abrupt('return', this.model.send(op));
return _context14.abrupt('return', this.send(op));

@@ -703,3 +703,3 @@ case 15:

function remove(_x17, _x18, _x19) {
return ref.apply(this, arguments);
return _ref14.apply(this, arguments);
}

@@ -712,3 +712,3 @@

value: function () {
var ref = (0, _asyncToGenerator3.default)(_regenerator2.default.mark(function _callee15(field, from, to) {
var _ref15 = (0, _asyncToGenerator3.default)(_regenerator2.default.mark(function _callee15(field, from, to) {
var howMany = arguments.length <= 3 || arguments[3] === undefined ? 1 : arguments[3];

@@ -782,3 +782,3 @@

});
return _context15.abrupt('return', this.model.send(op));
return _context15.abrupt('return', this.send(op));

@@ -794,3 +794,3 @@ case 17:

function move(_x21, _x22, _x23, _x24) {
return ref.apply(this, arguments);
return _ref15.apply(this, arguments);
}

@@ -803,3 +803,3 @@

value: function () {
var ref = (0, _asyncToGenerator3.default)(_regenerator2.default.mark(function _callee16(field, from, to) {
var _ref16 = (0, _asyncToGenerator3.default)(_regenerator2.default.mark(function _callee16(field, from, to) {
var array, positionId, itemId, op;

@@ -858,3 +858,3 @@ return _regenerator2.default.wrap(function _callee16$(_context16) {

function swap(_x26, _x27, _x28) {
return ref.apply(this, arguments);
return _ref16.apply(this, arguments);
}

@@ -867,3 +867,3 @@

value: function () {
var ref = (0, _asyncToGenerator3.default)(_regenerator2.default.mark(function _callee17(field, value) {
var _ref17 = (0, _asyncToGenerator3.default)(_regenerator2.default.mark(function _callee17(field, value) {
var array, op;

@@ -900,3 +900,3 @@ return _regenerator2.default.wrap(function _callee17$(_context17) {

function arraySet(_x29, _x30) {
return ref.apply(this, arguments);
return _ref17.apply(this, arguments);
}

@@ -909,3 +909,3 @@

value: function () {
var ref = (0, _asyncToGenerator3.default)(_regenerator2.default.mark(function _callee18(field, value) {
var _ref18 = (0, _asyncToGenerator3.default)(_regenerator2.default.mark(function _callee18(field, value) {
var previous, diffs, promises, _iteratorNormalCompletion3, _didIteratorError3, _iteratorError3, _iterator3, _step3, diff;

@@ -1003,3 +1003,3 @@

function arrayDiff(_x31, _x32) {
return ref.apply(this, arguments);
return _ref18.apply(this, arguments);
}

@@ -1012,3 +1012,3 @@

value: function () {
var ref = (0, _asyncToGenerator3.default)(_regenerator2.default.mark(function _callee19(field) {
var _ref19 = (0, _asyncToGenerator3.default)(_regenerator2.default.mark(function _callee19(field) {
var op;

@@ -1041,3 +1041,3 @@ return _regenerator2.default.wrap(function _callee19$(_context19) {

function invert(_x33) {
return ref.apply(this, arguments);
return _ref19.apply(this, arguments);
}

@@ -1050,3 +1050,3 @@

value: function () {
var ref = (0, _asyncToGenerator3.default)(_regenerator2.default.mark(function _callee20(field, value) {
var _ref20 = (0, _asyncToGenerator3.default)(_regenerator2.default.mark(function _callee20(field, value) {
var op;

@@ -1080,3 +1080,3 @@ return _regenerator2.default.wrap(function _callee20$(_context20) {

function increment(_x34, _x35) {
return ref.apply(this, arguments);
return _ref20.apply(this, arguments);
}

@@ -1089,3 +1089,3 @@

value: function () {
var ref = (0, _asyncToGenerator3.default)(_regenerator2.default.mark(function _callee21(field, index, value) {
var _ref21 = (0, _asyncToGenerator3.default)(_regenerator2.default.mark(function _callee21(field, index, value) {
var howMany, string, positionId, ops, type, _iteratorNormalCompletion4, _didIteratorError4, _iteratorError4, _iterator4, _step4, _value, charId, _op4, op;

@@ -1191,3 +1191,3 @@

});
return _context21.abrupt('return', this.model.send(op));
return _context21.abrupt('return', this.send(op));

@@ -1203,3 +1203,3 @@ case 33:

function stringInsert(_x36, _x37, _x38) {
return ref.apply(this, arguments);
return _ref21.apply(this, arguments);
}

@@ -1212,3 +1212,3 @@

value: function () {
var ref = (0, _asyncToGenerator3.default)(_regenerator2.default.mark(function _callee22(field, index) {
var _ref22 = (0, _asyncToGenerator3.default)(_regenerator2.default.mark(function _callee22(field, index) {
var howMany = arguments.length <= 2 || arguments[2] === undefined ? 1 : arguments[2];

@@ -1284,3 +1284,3 @@

});
return _context22.abrupt('return', this.model.send(op));
return _context22.abrupt('return', this.send(op));

@@ -1296,3 +1296,3 @@ case 16:

function stringRemove(_x39, _x40, _x41) {
return ref.apply(this, arguments);
return _ref22.apply(this, arguments);
}

@@ -1305,3 +1305,3 @@

value: function () {
var ref = (0, _asyncToGenerator3.default)(_regenerator2.default.mark(function _callee23(field, value) {
var _ref23 = (0, _asyncToGenerator3.default)(_regenerator2.default.mark(function _callee23(field, value) {
var string, op;

@@ -1338,3 +1338,3 @@ return _regenerator2.default.wrap(function _callee23$(_context23) {

function stringSet(_x43, _x44) {
return ref.apply(this, arguments);
return _ref23.apply(this, arguments);
}

@@ -1347,3 +1347,3 @@

value: function () {
var ref = (0, _asyncToGenerator3.default)(_regenerator2.default.mark(function _callee24(field, value) {
var _ref24 = (0, _asyncToGenerator3.default)(_regenerator2.default.mark(function _callee24(field, value) {
var previous, start, end, promises, howMany, inserted;

@@ -1402,3 +1402,3 @@ return _regenerator2.default.wrap(function _callee24$(_context24) {

function stringDiff(_x45, _x46) {
return ref.apply(this, arguments);
return _ref24.apply(this, arguments);
}

@@ -1411,3 +1411,3 @@

value: function () {
var ref = (0, _asyncToGenerator3.default)(_regenerator2.default.mark(function _callee25(field, value) {
var _ref25 = (0, _asyncToGenerator3.default)(_regenerator2.default.mark(function _callee25(field, value) {
var op;

@@ -1438,3 +1438,3 @@ return _regenerator2.default.wrap(function _callee25$(_context25) {

function rich(_x47, _x48) {
return ref.apply(this, arguments);
return _ref25.apply(this, arguments);
}

@@ -1548,5 +1548,5 @@

}, {
key: 'onOp',
key: 'send',
value: function () {
var ref = (0, _asyncToGenerator3.default)(_regenerator2.default.mark(function _callee26(op) {
var _ref26 = (0, _asyncToGenerator3.default)(_regenerator2.default.mark(function _callee26(op) {
return _regenerator2.default.wrap(function _callee26$(_context26) {

@@ -1556,17 +1556,41 @@ while (1) {

case 0:
return _context26.abrupt('return', this.model.send(op));
case 1:
case 'end':
return _context26.stop();
}
}
}, _callee26, this);
}));
function send(_x49) {
return _ref26.apply(this, arguments);
}
return send;
}()
}, {
key: 'onOp',
value: function () {
var _ref27 = (0, _asyncToGenerator3.default)(_regenerator2.default.mark(function _callee27(op) {
return _regenerator2.default.wrap(function _callee27$(_context27) {
while (1) {
switch (_context27.prev = _context27.next) {
case 0:
this.applyOp(op);
this.emit('change');
this.collection.emit('change', op);
return _context26.abrupt('return', this.save());
return _context27.abrupt('return', this.save());
case 4:
case 'end':
return _context26.stop();
return _context27.stop();
}
}
}, _callee26, this);
}, _callee27, this);
}));
function onOp(_x49) {
return ref.apply(this, arguments);
function onOp(_x50) {
return _ref27.apply(this, arguments);
}

@@ -1579,15 +1603,15 @@

value: function () {
var ref = (0, _asyncToGenerator3.default)(_regenerator2.default.mark(function _callee27() {
var _ref28 = (0, _asyncToGenerator3.default)(_regenerator2.default.mark(function _callee28() {
var _this2 = this;
return _regenerator2.default.wrap(function _callee27$(_context27) {
return _regenerator2.default.wrap(function _callee28$(_context28) {
while (1) {
switch (_context27.prev = _context27.next) {
switch (_context28.prev = _context28.next) {
case 0:
if (!(!this.model.storage || !this.ops.length)) {
_context27.next = 2;
_context28.next = 2;
break;
}
return _context27.abrupt('return');
return _context28.abrupt('return');

@@ -1603,10 +1627,10 @@ case 2:

case 'end':
return _context27.stop();
return _context28.stop();
}
}
}, _callee27, this);
}, _callee28, this);
}));
function save() {
return ref.apply(this, arguments);
return _ref28.apply(this, arguments);
}

@@ -1619,10 +1643,10 @@

value: function () {
var ref = (0, _asyncToGenerator3.default)(_regenerator2.default.mark(function _callee28() {
var _ref29 = (0, _asyncToGenerator3.default)(_regenerator2.default.mark(function _callee29() {
var _this3 = this;
return _regenerator2.default.wrap(function _callee28$(_context28) {
return _regenerator2.default.wrap(function _callee29$(_context29) {
while (1) {
switch (_context28.prev = _context28.next) {
switch (_context29.prev = _context29.next) {
case 0:
return _context28.abrupt('return', this.model.storage.saveDoc(this.collection.name, this.docId, this.ops, this.serverVersion).catch(function (err) {
return _context29.abrupt('return', this.model.storage.saveDoc(this.collection.name, this.docId, this.ops, this.serverVersion).catch(function (err) {
console.error('MutableDoc.save', _this3.collection.name, err);

@@ -1634,10 +1658,10 @@ console.log('Probably, you have not added collection ' + _this3.collection.name + '\n to store options. For IndexedDB app version should be increased also');

case 'end':
return _context28.stop();
return _context29.stop();
}
}
}, _callee28, this);
}, _callee29, this);
}));
function saveToStorage() {
return ref.apply(this, arguments);
return _ref29.apply(this, arguments);
}

@@ -1644,0 +1668,0 @@

@@ -60,3 +60,3 @@ 'use strict';

value: function () {
var ref = (0, _asyncToGenerator3.default)(_regenerator2.default.mark(function _callee(docId, docData) {
var _ref = (0, _asyncToGenerator3.default)(_regenerator2.default.mark(function _callee(docId, docData) {
var doc, op;

@@ -94,3 +94,3 @@ return _regenerator2.default.wrap(function _callee$(_context) {

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

@@ -97,0 +97,0 @@

@@ -81,3 +81,3 @@ 'use strict';

value: function () {
var ref = (0, _asyncToGenerator3.default)(_regenerator2.default.mark(function _callee() {
var _ref = (0, _asyncToGenerator3.default)(_regenerator2.default.mark(function _callee() {
return _regenerator2.default.wrap(function _callee$(_context) {

@@ -113,3 +113,3 @@ while (1) {

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

@@ -122,3 +122,3 @@

value: function () {
var ref = (0, _asyncToGenerator3.default)(_regenerator2.default.mark(function _callee2(options) {
var _ref2 = (0, _asyncToGenerator3.default)(_regenerator2.default.mark(function _callee2(options) {
return _regenerator2.default.wrap(function _callee2$(_context2) {

@@ -153,3 +153,3 @@ while (1) {

function subscribe(_x) {
return ref.apply(this, arguments);
return _ref2.apply(this, arguments);
}

@@ -162,3 +162,3 @@

value: function () {
var ref = (0, _asyncToGenerator3.default)(_regenerator2.default.mark(function _callee3() {
var _ref3 = (0, _asyncToGenerator3.default)(_regenerator2.default.mark(function _callee3() {
return _regenerator2.default.wrap(function _callee3$(_context3) {

@@ -184,3 +184,3 @@ while (1) {

function sendSubscribeOp() {
return ref.apply(this, arguments);
return _ref3.apply(this, arguments);
}

@@ -193,3 +193,3 @@

value: function () {
var ref = (0, _asyncToGenerator3.default)(_regenerator2.default.mark(function _callee4() {
var _ref4 = (0, _asyncToGenerator3.default)(_regenerator2.default.mark(function _callee4() {
return _regenerator2.default.wrap(function _callee4$(_context4) {

@@ -224,3 +224,3 @@ while (1) {

function unsubscribe() {
return ref.apply(this, arguments);
return _ref4.apply(this, arguments);
}

@@ -268,3 +268,3 @@

value: function () {
var ref = (0, _asyncToGenerator3.default)(_regenerator2.default.mark(function _callee5(op) {
var _ref5 = (0, _asyncToGenerator3.default)(_regenerator2.default.mark(function _callee5(op) {
return _regenerator2.default.wrap(function _callee5$(_context5) {

@@ -298,3 +298,3 @@ while (1) {

function onOp(_x2) {
return ref.apply(this, arguments);
return _ref5.apply(this, arguments);
}

@@ -301,0 +301,0 @@

@@ -120,4 +120,4 @@ 'use strict';

value: function () {
var ref = (0, _asyncToGenerator3.default)(_regenerator2.default.mark(function _callee() {
var prevData, _iteratorNormalCompletion, _didIteratorError, _iteratorError, _iterator, _step, subscribe, _queryOptions, rootValue, contextValue, variableValues, operationName, source, documentAST, _ref, data;
var _ref = (0, _asyncToGenerator3.default)(_regenerator2.default.mark(function _callee() {
var prevData, _iteratorNormalCompletion, _didIteratorError, _iteratorError, _iterator, _step, subscribe, _queryOptions, rootValue, contextValue, variableValues, operationName, source, documentAST, _ref2, data;

@@ -195,4 +195,4 @@ return _regenerator2.default.wrap(function _callee$(_context) {

case 31:
_ref = _context.sent;
data = _ref.data;
_ref2 = _context.sent;
data = _ref2.data;

@@ -214,3 +214,3 @@ this.data = data;

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

@@ -223,3 +223,3 @@

value: function () {
var ref = (0, _asyncToGenerator3.default)(_regenerator2.default.mark(function _callee2() {
var _ref3 = (0, _asyncToGenerator3.default)(_regenerator2.default.mark(function _callee2() {
var op;

@@ -265,3 +265,3 @@ return _regenerator2.default.wrap(function _callee2$(_context2) {

function fetch() {
return ref.apply(this, arguments);
return _ref3.apply(this, arguments);
}

@@ -274,3 +274,3 @@

value: function () {
var ref = (0, _asyncToGenerator3.default)(_regenerator2.default.mark(function _callee3(options) {
var _ref4 = (0, _asyncToGenerator3.default)(_regenerator2.default.mark(function _callee3(options) {
var op;

@@ -327,3 +327,3 @@ return _regenerator2.default.wrap(function _callee3$(_context3) {

function subscribe(_x2) {
return ref.apply(this, arguments);
return _ref4.apply(this, arguments);
}

@@ -336,3 +336,3 @@

value: function () {
var ref = (0, _asyncToGenerator3.default)(_regenerator2.default.mark(function _callee4() {
var _ref5 = (0, _asyncToGenerator3.default)(_regenerator2.default.mark(function _callee4() {
return _regenerator2.default.wrap(function _callee4$(_context4) {

@@ -370,3 +370,3 @@ while (1) {

function unsubscribe() {
return ref.apply(this, arguments);
return _ref5.apply(this, arguments);
}

@@ -373,0 +373,0 @@

@@ -73,3 +73,3 @@ 'use strict';

value: function () {
var ref = (0, _asyncToGenerator3.default)(_regenerator2.default.mark(function _callee() {
var _ref = (0, _asyncToGenerator3.default)(_regenerator2.default.mark(function _callee() {
var op;

@@ -114,3 +114,3 @@ return _regenerator2.default.wrap(function _callee$(_context) {

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

@@ -123,3 +123,3 @@

value: function () {
var ref = (0, _asyncToGenerator3.default)(_regenerator2.default.mark(function _callee2(options) {
var _ref2 = (0, _asyncToGenerator3.default)(_regenerator2.default.mark(function _callee2(options) {
var op;

@@ -176,3 +176,3 @@ return _regenerator2.default.wrap(function _callee2$(_context2) {

function subscribe(_x) {
return ref.apply(this, arguments);
return _ref2.apply(this, arguments);
}

@@ -185,3 +185,3 @@

value: function () {
var ref = (0, _asyncToGenerator3.default)(_regenerator2.default.mark(function _callee3() {
var _ref3 = (0, _asyncToGenerator3.default)(_regenerator2.default.mark(function _callee3() {
return _regenerator2.default.wrap(function _callee3$(_context3) {

@@ -219,3 +219,3 @@ while (1) {

function unsubscribe() {
return ref.apply(this, arguments);
return _ref3.apply(this, arguments);
}

@@ -222,0 +222,0 @@

@@ -152,3 +152,3 @@ 'use strict';

value: function () {
var ref = (0, _asyncToGenerator3.default)(_regenerator2.default.mark(function _callee() {
var _ref = (0, _asyncToGenerator3.default)(_regenerator2.default.mark(function _callee() {
return _regenerator2.default.wrap(function _callee$(_context) {

@@ -171,3 +171,3 @@ while (1) {

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

@@ -180,3 +180,3 @@

value: function () {
var ref = (0, _asyncToGenerator3.default)(_regenerator2.default.mark(function _callee2() {
var _ref2 = (0, _asyncToGenerator3.default)(_regenerator2.default.mark(function _callee2() {
var promises, i, _subscribe, subscribeOptions, promise;

@@ -216,3 +216,3 @@

function subscribe() {
return ref.apply(this, arguments);
return _ref2.apply(this, arguments);
}

@@ -225,3 +225,3 @@

value: function () {
var ref = (0, _asyncToGenerator3.default)(_regenerator2.default.mark(function _callee3() {
var _ref3 = (0, _asyncToGenerator3.default)(_regenerator2.default.mark(function _callee3() {
var _iteratorNormalCompletion2, _didIteratorError2, _iteratorError2, _iterator2, _step2, subscribe;

@@ -290,3 +290,3 @@

function unsubscribe() {
return ref.apply(this, arguments);
return _ref3.apply(this, arguments);
}

@@ -299,3 +299,3 @@

value: function () {
var ref = (0, _asyncToGenerator3.default)(_regenerator2.default.mark(function _callee4(nextRawSubscribes) {
var _ref4 = (0, _asyncToGenerator3.default)(_regenerator2.default.mark(function _callee4(nextRawSubscribes) {
return _regenerator2.default.wrap(function _callee4$(_context4) {

@@ -318,3 +318,3 @@ while (1) {

function changeSubscribes(_x) {
return ref.apply(this, arguments);
return _ref4.apply(this, arguments);
}

@@ -321,0 +321,0 @@

@@ -44,3 +44,8 @@ 'use strict';

var fetchOptions = {
credentials: 'include'
credentials: 'include',
headers: {
expires: '0',
pragma: 'no-cache',
'cache-control': 'no-cache'
}
};

@@ -64,2 +69,3 @@

_this.fetching = false;
_this.fetched = false;
return _this;

@@ -76,3 +82,3 @@ }

value: function () {
var ref = (0, _asyncToGenerator3.default)(_regenerator2.default.mark(function _callee() {
var _ref = (0, _asyncToGenerator3.default)(_regenerator2.default.mark(function _callee() {
var res;

@@ -83,3 +89,3 @@ return _regenerator2.default.wrap(function _callee$(_context) {

case 0:
if (this.model.online) {
if (!(!this.model.online || this.fetched)) {
_context.next = 2;

@@ -126,5 +132,8 @@ break;

case 19:
this.fetching = false;
this.fetched = true;
this.emit('change');
case 20:
case 22:
case 'end':

@@ -138,3 +147,3 @@ return _context.stop();

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

@@ -147,3 +156,3 @@

value: function () {
var ref = (0, _asyncToGenerator3.default)(_regenerator2.default.mark(function _callee2() {
var _ref2 = (0, _asyncToGenerator3.default)(_regenerator2.default.mark(function _callee2() {
return _regenerator2.default.wrap(function _callee2$(_context2) {

@@ -172,3 +181,3 @@ while (1) {

function fetch() {
return ref.apply(this, arguments);
return _ref2.apply(this, arguments);
}

@@ -181,3 +190,3 @@

value: function () {
var ref = (0, _asyncToGenerator3.default)(_regenerator2.default.mark(function _callee3(options) {
var _ref3 = (0, _asyncToGenerator3.default)(_regenerator2.default.mark(function _callee3(options) {
return _regenerator2.default.wrap(function _callee3$(_context3) {

@@ -210,3 +219,3 @@ while (1) {

function subscribe(_x) {
return ref.apply(this, arguments);
return _ref3.apply(this, arguments);
}

@@ -219,3 +228,3 @@

value: function () {
var ref = (0, _asyncToGenerator3.default)(_regenerator2.default.mark(function _callee4() {
var _ref4 = (0, _asyncToGenerator3.default)(_regenerator2.default.mark(function _callee4() {
return _regenerator2.default.wrap(function _callee4$(_context4) {

@@ -233,3 +242,3 @@ while (1) {

function unsubscribe() {
return ref.apply(this, arguments);
return _ref4.apply(this, arguments);
}

@@ -236,0 +245,0 @@

@@ -52,3 +52,3 @@ 'use strict';

value: function () {
var ref = (0, _asyncToGenerator3.default)(_regenerator2.default.mark(function _callee(collectionName, docId) {
var _ref = (0, _asyncToGenerator3.default)(_regenerator2.default.mark(function _callee(collectionName, docId) {
var hash, doc, projection;

@@ -97,3 +97,3 @@ return _regenerator2.default.wrap(function _callee$(_context) {

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

@@ -100,0 +100,0 @@

@@ -75,3 +75,3 @@ 'use strict';

_this.resolve = function () {
var ref = (0, _asyncToGenerator3.default)(_regenerator2.default.mark(function _callee(collectionName, docIdOrExpression) {
var _ref = (0, _asyncToGenerator3.default)(_regenerator2.default.mark(function _callee(collectionName, docIdOrExpression) {
var isQuery, subscribe;

@@ -131,4 +131,5 @@ return _regenerator2.default.wrap(function _callee$(_context) {

}));
return function (_x2, _x3) {
return ref.apply(this, arguments);
return _ref.apply(this, arguments);
};

@@ -159,6 +160,6 @@ }();

value: function () {
var ref = (0, _asyncToGenerator3.default)(_regenerator2.default.mark(function _callee2() {
var _ref2 = (0, _asyncToGenerator3.default)(_regenerator2.default.mark(function _callee2() {
var _this3 = this;
var _iteratorNormalCompletion, _didIteratorError, _iteratorError, _iterator, _step, subscribe, _iteratorNormalCompletion2, _didIteratorError2, _iteratorError2, _iterator2, _step2, channel, _queryOptions, rootValue, contextValue, variableValues, operationName, source, documentAST, _ref, data;
var _iteratorNormalCompletion, _didIteratorError, _iteratorError, _iterator, _step, subscribe, _iteratorNormalCompletion2, _didIteratorError2, _iteratorError2, _iterator2, _step2, channel, _queryOptions, rootValue, contextValue, variableValues, operationName, source, documentAST, _ref3, data;

@@ -299,4 +300,4 @@ return _regenerator2.default.wrap(function _callee2$(_context2) {

case 62:
_ref = _context2.sent;
data = _ref.data;
_ref3 = _context2.sent;
data = _ref3.data;

@@ -328,3 +329,3 @@ this.data = data;

function load() {
return ref.apply(this, arguments);
return _ref2.apply(this, arguments);
}

@@ -342,3 +343,3 @@

value: function () {
var ref = (0, _asyncToGenerator3.default)(_regenerator2.default.mark(function _callee3(channel, ackId) {
var _ref4 = (0, _asyncToGenerator3.default)(_regenerator2.default.mark(function _callee3(channel, ackId) {
var op;

@@ -369,3 +370,3 @@ return _regenerator2.default.wrap(function _callee3$(_context3) {

function sendNotDocsQuerySnapshotToChannel(_x4, _x5) {
return ref.apply(this, arguments);
return _ref4.apply(this, arguments);
}

@@ -378,3 +379,3 @@

value: function () {
var ref = (0, _asyncToGenerator3.default)(_regenerator2.default.mark(function _callee4(channel, docIds, ackId) {
var _ref5 = (0, _asyncToGenerator3.default)(_regenerator2.default.mark(function _callee4(channel, docIds, ackId) {
return _regenerator2.default.wrap(function _callee4$(_context4) {

@@ -400,3 +401,3 @@ while (1) {

function fetch(_x6, _x7, _x8) {
return ref.apply(this, arguments);
return _ref5.apply(this, arguments);
}

@@ -409,3 +410,3 @@

value: function () {
var ref = (0, _asyncToGenerator3.default)(_regenerator2.default.mark(function _callee5(channel, docIds, ackId) {
var _ref6 = (0, _asyncToGenerator3.default)(_regenerator2.default.mark(function _callee5(channel, docIds, ackId) {
var _iteratorNormalCompletion3, _didIteratorError3, _iteratorError3, _iterator3, _step3, _subscribe;

@@ -474,3 +475,3 @@

function subscribe(_x9, _x10, _x11) {
return ref.apply(this, arguments);
return _ref6.apply(this, arguments);
}

@@ -477,0 +478,0 @@

@@ -118,3 +118,3 @@ 'use strict';

value: function () {
var ref = (0, _asyncToGenerator3.default)(_regenerator2.default.mark(function _callee() {
var _ref = (0, _asyncToGenerator3.default)(_regenerator2.default.mark(function _callee() {
var _this2 = this;

@@ -166,3 +166,3 @@

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

@@ -169,0 +169,0 @@

@@ -232,3 +232,3 @@ 'use strict';

value: function () {
var ref = (0, _asyncToGenerator3.default)(_regenerator2.default.mark(function _callee(channel, diffs, ackId) {
var _ref = (0, _asyncToGenerator3.default)(_regenerator2.default.mark(function _callee(channel, diffs, ackId) {
var docMap, _iteratorNormalCompletion4, _didIteratorError4, _iteratorError4, _iterator4, _step4, doc, docOps, docVersions, _iteratorNormalCompletion5, _didIteratorError5, _iteratorError5, _iterator5, _step5, diff, _iteratorNormalCompletion6, _didIteratorError6, _iteratorError6, _iterator6, _step6, docId, op;

@@ -415,3 +415,3 @@

function sendDiffQueryToChannel(_x, _x2, _x3) {
return ref.apply(this, arguments);
return _ref.apply(this, arguments);
}

@@ -439,3 +439,3 @@

value: function () {
var ref = (0, _asyncToGenerator3.default)(_regenerator2.default.mark(function _callee2(docVersions, channel) {
var _ref2 = (0, _asyncToGenerator3.default)(_regenerator2.default.mark(function _callee2(docVersions, channel) {
var _this3 = this;

@@ -465,3 +465,3 @@

function subscribeDocs(_x5, _x6) {
return ref.apply(this, arguments);
return _ref2.apply(this, arguments);
}

@@ -474,3 +474,3 @@

value: function () {
var ref = (0, _asyncToGenerator3.default)(_regenerator2.default.mark(function _callee3(channel, docIds, ackId) {
var _ref3 = (0, _asyncToGenerator3.default)(_regenerator2.default.mark(function _callee3(channel, docIds, ackId) {
return _regenerator2.default.wrap(function _callee3$(_context3) {

@@ -496,3 +496,3 @@ while (1) {

function fetch(_x7, _x8, _x9) {
return ref.apply(this, arguments);
return _ref3.apply(this, arguments);
}

@@ -505,3 +505,3 @@

value: function () {
var ref = (0, _asyncToGenerator3.default)(_regenerator2.default.mark(function _callee4(channel, docIds, ackId) {
var _ref4 = (0, _asyncToGenerator3.default)(_regenerator2.default.mark(function _callee4(channel, docIds, ackId) {
return _regenerator2.default.wrap(function _callee4$(_context4) {

@@ -525,3 +525,3 @@ while (1) {

function subscribe(_x10, _x11, _x12) {
return ref.apply(this, arguments);
return _ref4.apply(this, arguments);
}

@@ -534,3 +534,3 @@

value: function () {
var ref = (0, _asyncToGenerator3.default)(_regenerator2.default.mark(function _callee5(channel, docIds, ackId) {
var _ref5 = (0, _asyncToGenerator3.default)(_regenerator2.default.mark(function _callee5(channel, docIds, ackId) {
var diffs;

@@ -567,3 +567,3 @@ return _regenerator2.default.wrap(function _callee5$(_context5) {

function sendQuery(_x13, _x14, _x15) {
return ref.apply(this, arguments);
return _ref5.apply(this, arguments);
}

@@ -570,0 +570,0 @@

@@ -64,3 +64,3 @@ 'use strict';

value: function () {
var ref = (0, _asyncToGenerator3.default)(_regenerator2.default.mark(function _callee(collectionName, expression) {
var _ref = (0, _asyncToGenerator3.default)(_regenerator2.default.mark(function _callee(collectionName, expression) {
var hash, query;

@@ -103,3 +103,3 @@ return _regenerator2.default.wrap(function _callee$(_context) {

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

@@ -106,0 +106,0 @@

@@ -112,3 +112,3 @@ 'use strict';

_this.onConnection = function () {
var ref = (0, _asyncToGenerator3.default)(_regenerator2.default.mark(function _callee(socket) {
var _ref = (0, _asyncToGenerator3.default)(_regenerator2.default.mark(function _callee(socket) {
var channel, _this$getHookParams, session, params;

@@ -156,4 +156,5 @@

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

@@ -271,3 +272,3 @@ }();

value: function () {
var ref = (0, _asyncToGenerator3.default)(_regenerator2.default.mark(function _callee2(ackId, collectionName, docId, field, newOps, channel, opsType, index, howMany) {
var _ref2 = (0, _asyncToGenerator3.default)(_regenerator2.default.mark(function _callee2(ackId, collectionName, docId, field, newOps, channel, opsType, index, howMany) {
var doc, ops, prevs, _iteratorNormalCompletion, _didIteratorError, _iteratorError, _iterator, _step, _op2, valid, _prev, op, i, _op, prev;

@@ -403,3 +404,3 @@

function onDocOps(_x3, _x4, _x5, _x6, _x7, _x8, _x9, _x10, _x11) {
return ref.apply(this, arguments);
return _ref2.apply(this, arguments);
}

@@ -412,3 +413,3 @@

value: function () {
var ref = (0, _asyncToGenerator3.default)(_regenerator2.default.mark(function _callee3(op, channel) {
var _ref3 = (0, _asyncToGenerator3.default)(_regenerator2.default.mark(function _callee3(op, channel) {
var id, collectionName, docId, _getHookParams, session, params, _op3;

@@ -464,3 +465,3 @@

function validateOp(_x12, _x13) {
return ref.apply(this, arguments);
return _ref3.apply(this, arguments);
}

@@ -473,3 +474,3 @@

value: function () {
var ref = (0, _asyncToGenerator3.default)(_regenerator2.default.mark(function _callee4(op, channel, prev) {
var _ref4 = (0, _asyncToGenerator3.default)(_regenerator2.default.mark(function _callee4(op, channel, prev) {
var _getHookParams2, session, params;

@@ -513,3 +514,3 @@

function afterOp(_x14, _x15, _x16) {
return ref.apply(this, arguments);
return _ref4.apply(this, arguments);
}

@@ -529,3 +530,3 @@

value: function () {
var ref = (0, _asyncToGenerator3.default)(_regenerator2.default.mark(function _callee5(message, channel) {
var _ref5 = (0, _asyncToGenerator3.default)(_regenerator2.default.mark(function _callee5(message, channel) {
var _this3 = this;

@@ -803,3 +804,3 @@

function onMessage(_x17, _x18) {
return ref.apply(this, arguments);
return _ref5.apply(this, arguments);
}

@@ -806,0 +807,0 @@

@@ -24,2 +24,2 @@ "use strict";

exports.default = Char;
module.exports = exports['default'];
module.exports = exports["default"];

@@ -24,2 +24,2 @@ "use strict";

exports.default = Item;
module.exports = exports['default'];
module.exports = exports["default"];

@@ -40,2 +40,2 @@ "use strict";

exports.default = RichTextType;
module.exports = exports['default'];
module.exports = exports["default"];

@@ -64,2 +64,4 @@ 'use strict';

if (path.indexOf('http') === 0 || path.indexOf('/') === 0) return [path];
var _path$split = path.split('.');

@@ -66,0 +68,0 @@

@@ -20,3 +20,3 @@ 'use strict';

var onBundleReady = function () {
var ref = (0, _asyncToGenerator3.default)(_regenerator2.default.mark(function _callee() {
var _ref = (0, _asyncToGenerator3.default)(_regenerator2.default.mark(function _callee() {
return _regenerator2.default.wrap(function _callee$(_context) {

@@ -41,4 +41,5 @@ while (1) {

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

@@ -45,0 +46,0 @@ }();

@@ -58,3 +58,3 @@ 'use strict';

value: function () {
var ref = (0, _asyncToGenerator3.default)(_regenerator2.default.mark(function _callee() {
var _ref = (0, _asyncToGenerator3.default)(_regenerator2.default.mark(function _callee() {
return _regenerator2.default.wrap(function _callee$(_context) {

@@ -75,3 +75,3 @@ while (1) {

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

@@ -89,3 +89,3 @@

value: function () {
var ref = (0, _asyncToGenerator3.default)(_regenerator2.default.mark(function _callee2() {
var _ref2 = (0, _asyncToGenerator3.default)(_regenerator2.default.mark(function _callee2() {
var _this = this;

@@ -162,3 +162,3 @@

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

@@ -180,3 +180,3 @@

value: function () {
var ref = (0, _asyncToGenerator3.default)(_regenerator2.default.mark(function _callee3(collectionName) {
var _ref3 = (0, _asyncToGenerator3.default)(_regenerator2.default.mark(function _callee3(collectionName) {
var _this2 = this;

@@ -216,3 +216,3 @@

function getAllDocs(_x) {
return ref.apply(this, arguments);
return _ref3.apply(this, arguments);
}

@@ -225,3 +225,3 @@

value: function () {
var ref = (0, _asyncToGenerator3.default)(_regenerator2.default.mark(function _callee4(collectionName) {
var _ref4 = (0, _asyncToGenerator3.default)(_regenerator2.default.mark(function _callee4(collectionName) {
var _this3 = this;

@@ -253,3 +253,3 @@

function clearCollection(_x2) {
return ref.apply(this, arguments);
return _ref4.apply(this, arguments);
}

@@ -262,3 +262,3 @@

value: function () {
var ref = (0, _asyncToGenerator3.default)(_regenerator2.default.mark(function _callee5() {
var _ref5 = (0, _asyncToGenerator3.default)(_regenerator2.default.mark(function _callee5() {
var promises, _iteratorNormalCompletion2, _didIteratorError2, _iteratorError2, _iterator2, _step2, collectionName;

@@ -328,3 +328,3 @@

function clear() {
return ref.apply(this, arguments);
return _ref5.apply(this, arguments);
}

@@ -342,3 +342,3 @@

value: function () {
var ref = (0, _asyncToGenerator3.default)(_regenerator2.default.mark(function _callee6(collectionName, docId, ops, serverVersion) {
var _ref6 = (0, _asyncToGenerator3.default)(_regenerator2.default.mark(function _callee6(collectionName, docId, ops, serverVersion) {
var _this4 = this;

@@ -376,3 +376,3 @@

function saveDoc(_x3, _x4, _x5, _x6) {
return ref.apply(this, arguments);
return _ref6.apply(this, arguments);
}

@@ -379,0 +379,0 @@

{
"name": "amelisa",
"version": "0.1.28",
"version": "0.1.33",
"description": "Data engine with offline and realtime",

@@ -5,0 +5,0 @@ "browser": "lib/web",

SocketSocket SOC 2 Logo

Product

  • Package Alerts
  • Integrations
  • Docs
  • Pricing
  • FAQ
  • Roadmap
  • Changelog

Packages

npm

Stay in touch

Get open source security insights delivered straight into your inbox.


  • Terms
  • Privacy
  • Security

Made with ⚡️ by Socket Inc