summaryrefslogtreecommitdiff
path: root/ext/lib/dexie-export-import.js
diff options
context:
space:
mode:
authorDarius Jahandarie <djahandarie@gmail.com>2023-11-09 13:30:31 +0000
committerGitHub <noreply@github.com>2023-11-09 13:30:31 +0000
commit5c5a167b4792af379cdacf633513cebf20728cd2 (patch)
tree5b6be3620a557d0b9177047003f6d742d9d2a32d /ext/lib/dexie-export-import.js
parentb64f51c3b13a46af4dd7f1e43048ac19c781ca7b (diff)
parent0f4d36938fd0d844f548aa5a7f7e7842df8dfb41 (diff)
Merge pull request #307 from themoeway/modernize
Modernize codebase
Diffstat (limited to 'ext/lib/dexie-export-import.js')
-rw-r--r--ext/lib/dexie-export-import.js3457
1 files changed, 0 insertions, 3457 deletions
diff --git a/ext/lib/dexie-export-import.js b/ext/lib/dexie-export-import.js
deleted file mode 100644
index f915d1c1..00000000
--- a/ext/lib/dexie-export-import.js
+++ /dev/null
@@ -1,3457 +0,0 @@
-/* ==========================================================================
- * dexie-export-import.js
- * ==========================================================================
- *
- * Dexie addon for exporting and importing databases to / from Blobs.
- *
- * By David Fahlander, david.fahlander@gmail.com,
- *
- * ==========================================================================
- *
- * Version 4.0.7, Wed Mar 29 2023
- *
- * https://dexie.org
- *
- * Apache License Version 2.0, January 2004, http://www.apache.org/licenses/
- *
- */
-
-(function (global, factory) {
- typeof exports === 'object' && typeof module !== 'undefined' ? factory(exports, require('dexie')) :
- typeof define === 'function' && define.amd ? define(['exports', 'dexie'], factory) :
- (global = typeof globalThis !== 'undefined' ? globalThis : global || self, factory(global.DexieExportImport = {}, global.Dexie));
-})(this, (function (exports, Dexie) { 'use strict';
-
- function _interopDefaultLegacy (e) { return e && typeof e === 'object' && 'default' in e ? e : { 'default': e }; }
-
- var Dexie__default = /*#__PURE__*/_interopDefaultLegacy(Dexie);
-
- /*! *****************************************************************************
- Copyright (c) Microsoft Corporation.
-
- Permission to use, copy, modify, and/or distribute this software for any
- purpose with or without fee is hereby granted.
-
- THE SOFTWARE IS PROVIDED "AS IS" AND THE AUTHOR DISCLAIMS ALL WARRANTIES WITH
- REGARD TO THIS SOFTWARE INCLUDING ALL IMPLIED WARRANTIES OF MERCHANTABILITY
- AND FITNESS. IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR ANY SPECIAL, DIRECT,
- INDIRECT, OR CONSEQUENTIAL DAMAGES OR ANY DAMAGES WHATSOEVER RESULTING FROM
- LOSS OF USE, DATA OR PROFITS, WHETHER IN AN ACTION OF CONTRACT, NEGLIGENCE OR
- OTHER TORTIOUS ACTION, ARISING OUT OF OR IN CONNECTION WITH THE USE OR
- PERFORMANCE OF THIS SOFTWARE.
- ***************************************************************************** */
-
- function __awaiter(thisArg, _arguments, P, generator) {
- function adopt(value) { return value instanceof P ? value : new P(function (resolve) { resolve(value); }); }
- return new (P || (P = Promise))(function (resolve, reject) {
- function fulfilled(value) { try { step(generator.next(value)); } catch (e) { reject(e); } }
- function rejected(value) { try { step(generator["throw"](value)); } catch (e) { reject(e); } }
- function step(result) { result.done ? resolve(result.value) : adopt(result.value).then(fulfilled, rejected); }
- step((generator = generator.apply(thisArg, _arguments || [])).next());
- });
- }
-
- function __generator(thisArg, body) {
- var _ = { label: 0, sent: function() { if (t[0] & 1) throw t[1]; return t[1]; }, trys: [], ops: [] }, f, y, t, g;
- return g = { next: verb(0), "throw": verb(1), "return": verb(2) }, typeof Symbol === "function" && (g[Symbol.iterator] = function() { return this; }), g;
- function verb(n) { return function (v) { return step([n, v]); }; }
- function step(op) {
- if (f) throw new TypeError("Generator is already executing.");
- while (_) try {
- if (f = 1, y && (t = op[0] & 2 ? y["return"] : op[0] ? y["throw"] || ((t = y["return"]) && t.call(y), 0) : y.next) && !(t = t.call(y, op[1])).done) return t;
- if (y = 0, t) op = [op[0] & 2, t.value];
- switch (op[0]) {
- case 0: case 1: t = op; break;
- case 4: _.label++; return { value: op[1], done: false };
- case 5: _.label++; y = op[1]; op = [0]; continue;
- case 7: op = _.ops.pop(); _.trys.pop(); continue;
- default:
- if (!(t = _.trys, t = t.length > 0 && t[t.length - 1]) && (op[0] === 6 || op[0] === 2)) { _ = 0; continue; }
- if (op[0] === 3 && (!t || (op[1] > t[0] && op[1] < t[3]))) { _.label = op[1]; break; }
- if (op[0] === 6 && _.label < t[1]) { _.label = t[1]; t = op; break; }
- if (t && _.label < t[2]) { _.label = t[2]; _.ops.push(op); break; }
- if (t[2]) _.ops.pop();
- _.trys.pop(); continue;
- }
- op = body.call(thisArg, _);
- } catch (e) { op = [6, e]; y = 0; } finally { f = t = 0; }
- if (op[0] & 5) throw op[1]; return { value: op[0] ? op[1] : void 0, done: true };
- }
- }
-
- function getSchemaString(table) {
- var primKeyAndIndexes = [table.schema.primKey].concat(table.schema.indexes);
- return primKeyAndIndexes.map(function (index) { return index.src; }).join(',');
- }
- function extractDbSchema(exportedDb) {
- var schema = {};
- for (var _i = 0, _a = exportedDb.tables; _i < _a.length; _i++) {
- var table = _a[_i];
- schema[table.name] = table.schema;
- }
- return schema;
- }
- function readBlobAsync(blob, type) {
- return new Promise(function (resolve, reject) {
- var reader = new FileReader();
- reader.onabort = function (ev) { return reject(new Error("file read aborted")); };
- reader.onerror = function (ev) { return reject(ev.target.error); };
- reader.onload = function (ev) { return resolve(ev.target.result); };
- if (type === 'binary')
- reader.readAsArrayBuffer(blob);
- else
- reader.readAsText(blob);
- });
- }
- function readBlobSync(blob, type) {
- if (typeof FileReaderSync === 'undefined') {
- throw new Error('FileReaderSync missing. Reading blobs synchronously requires code to run from within a web worker. Use TSON.encapsulateAsync() to do it from the main thread.');
- }
- var reader = new FileReaderSync(); // Requires worker environment
- var data = type === 'binary' ?
- reader.readAsArrayBuffer(blob) :
- reader.readAsText(blob);
- return data;
- }
-
- var commonjsGlobal = typeof globalThis !== 'undefined' ? globalThis : typeof window !== 'undefined' ? window : typeof global !== 'undefined' ? global : typeof self !== 'undefined' ? self : {};
-
- function createCommonjsModule(fn, module) {
- return module = { exports: {} }, fn(module, module.exports), module.exports;
- }
-
- var typeson = createCommonjsModule(function (module, exports) {
- (function (global, factory) {
- module.exports = factory() ;
- }(commonjsGlobal, (function () {
- function _typeof(obj) {
- if (typeof Symbol === "function" && typeof Symbol.iterator === "symbol") {
- _typeof = function (obj) {
- return typeof obj;
- };
- } else {
- _typeof = function (obj) {
- return obj && typeof Symbol === "function" && obj.constructor === Symbol && obj !== Symbol.prototype ? "symbol" : typeof obj;
- };
- }
-
- return _typeof(obj);
- }
-
- function asyncGeneratorStep(gen, resolve, reject, _next, _throw, key, arg) {
- try {
- var info = gen[key](arg);
- var value = info.value;
- } catch (error) {
- reject(error);
- return;
- }
-
- if (info.done) {
- resolve(value);
- } else {
- Promise.resolve(value).then(_next, _throw);
- }
- }
-
- function _asyncToGenerator(fn) {
- return function () {
- var self = this,
- args = arguments;
- return new Promise(function (resolve, reject) {
- var gen = fn.apply(self, args);
-
- function _next(value) {
- asyncGeneratorStep(gen, resolve, reject, _next, _throw, "next", value);
- }
-
- function _throw(err) {
- asyncGeneratorStep(gen, resolve, reject, _next, _throw, "throw", err);
- }
-
- _next(undefined);
- });
- };
- }
-
- function _classCallCheck(instance, Constructor) {
- if (!(instance instanceof Constructor)) {
- throw new TypeError("Cannot call a class as a function");
- }
- }
-
- function _defineProperties(target, props) {
- for (var i = 0; i < props.length; i++) {
- var descriptor = props[i];
- descriptor.enumerable = descriptor.enumerable || false;
- descriptor.configurable = true;
- if ("value" in descriptor) descriptor.writable = true;
- Object.defineProperty(target, descriptor.key, descriptor);
- }
- }
-
- function _createClass(Constructor, protoProps, staticProps) {
- if (protoProps) _defineProperties(Constructor.prototype, protoProps);
- if (staticProps) _defineProperties(Constructor, staticProps);
- return Constructor;
- }
-
- function _defineProperty(obj, key, value) {
- if (key in obj) {
- Object.defineProperty(obj, key, {
- value: value,
- enumerable: true,
- configurable: true,
- writable: true
- });
- } else {
- obj[key] = value;
- }
-
- return obj;
- }
-
- function ownKeys(object, enumerableOnly) {
- var keys = Object.keys(object);
-
- if (Object.getOwnPropertySymbols) {
- var symbols = Object.getOwnPropertySymbols(object);
- if (enumerableOnly) symbols = symbols.filter(function (sym) {
- return Object.getOwnPropertyDescriptor(object, sym).enumerable;
- });
- keys.push.apply(keys, symbols);
- }
-
- return keys;
- }
-
- function _objectSpread2(target) {
- for (var i = 1; i < arguments.length; i++) {
- var source = arguments[i] != null ? arguments[i] : {};
-
- if (i % 2) {
- ownKeys(Object(source), true).forEach(function (key) {
- _defineProperty(target, key, source[key]);
- });
- } else if (Object.getOwnPropertyDescriptors) {
- Object.defineProperties(target, Object.getOwnPropertyDescriptors(source));
- } else {
- ownKeys(Object(source)).forEach(function (key) {
- Object.defineProperty(target, key, Object.getOwnPropertyDescriptor(source, key));
- });
- }
- }
-
- return target;
- }
-
- function _slicedToArray(arr, i) {
- return _arrayWithHoles(arr) || _iterableToArrayLimit(arr, i) || _nonIterableRest();
- }
-
- function _toConsumableArray(arr) {
- return _arrayWithoutHoles(arr) || _iterableToArray(arr) || _nonIterableSpread();
- }
-
- function _arrayWithoutHoles(arr) {
- if (Array.isArray(arr)) {
- for (var i = 0, arr2 = new Array(arr.length); i < arr.length; i++) arr2[i] = arr[i];
-
- return arr2;
- }
- }
-
- function _arrayWithHoles(arr) {
- if (Array.isArray(arr)) return arr;
- }
-
- function _iterableToArray(iter) {
- if (Symbol.iterator in Object(iter) || Object.prototype.toString.call(iter) === "[object Arguments]") return Array.from(iter);
- }
-
- function _iterableToArrayLimit(arr, i) {
- if (!(Symbol.iterator in Object(arr) || Object.prototype.toString.call(arr) === "[object Arguments]")) {
- return;
- }
-
- 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"] != null) _i["return"]();
- } finally {
- if (_d) throw _e;
- }
- }
-
- return _arr;
- }
-
- function _nonIterableSpread() {
- throw new TypeError("Invalid attempt to spread non-iterable instance");
- }
-
- function _nonIterableRest() {
- throw new TypeError("Invalid attempt to destructure non-iterable instance");
- }
-
- /**
- * We keep this function minimized so if using two instances of this
- * library, where one is minimized and one is not, it will still work
- * with `hasConstructorOf`.
- * With ES6 classes, we may be able to simply use `class TypesonPromise
- * extends Promise` and add a string tag for detection.
- * @param {function} f
- */
- // eslint-disable-next-line max-len
- // eslint-disable-next-line block-spacing, space-before-function-paren, space-before-blocks, space-infix-ops, semi, promise/avoid-new
- var TypesonPromise = function TypesonPromise(f) {
- _classCallCheck(this, TypesonPromise);
-
- this.p = new Promise(f);
- }; // eslint-disable-next-line max-len
- // class TypesonPromise extends Promise {get[Symbol.toStringTag](){return 'TypesonPromise'};} // eslint-disable-line keyword-spacing, space-before-function-paren, space-before-blocks, block-spacing, semi
-
-
- TypesonPromise.__typeson__type__ = 'TypesonPromise'; // Note: core-js-bundle provides a `Symbol` polyfill
-
- /* istanbul ignore else */
-
- if (typeof Symbol !== 'undefined') {
- // Ensure `isUserObject` will return `false` for `TypesonPromise`
- TypesonPromise.prototype[Symbol.toStringTag] = 'TypesonPromise';
- }
- /**
- *
- * @param {function} [onFulfilled]
- * @param {function} [onRejected]
- * @returns {TypesonPromise}
- */
-
-
- TypesonPromise.prototype.then = function (onFulfilled, onRejected) {
- var _this = this;
-
- return new TypesonPromise(function (typesonResolve, typesonReject) {
- // eslint-disable-next-line promise/catch-or-return
- _this.p.then(function (res) {
- // eslint-disable-next-line promise/always-return
- typesonResolve(onFulfilled ? onFulfilled(res) : res);
- })["catch"](function (res) {
- return onRejected ? onRejected(res) : Promise.reject(res);
- }).then(typesonResolve, typesonReject);
- });
- };
- /**
- *
- * @param {function} onRejected
- * @returns {TypesonPromise}
- */
-
-
- TypesonPromise.prototype["catch"] = function (onRejected) {
- return this.then(null, onRejected);
- };
- /**
- *
- * @param {Any} v
- * @returns {TypesonPromise}
- */
-
-
- TypesonPromise.resolve = function (v) {
- return new TypesonPromise(function (typesonResolve) {
- typesonResolve(v);
- });
- };
- /**
- *
- * @param {Any} v
- * @returns {TypesonPromise}
- */
-
-
- TypesonPromise.reject = function (v) {
- return new TypesonPromise(function (typesonResolve, typesonReject) {
- typesonReject(v);
- });
- };
-
- ['all', 'race'].forEach(function (meth) {
- /**
- *
- * @param {Promise[]} promArr
- * @returns {TypesonPromise}
- */
- TypesonPromise[meth] = function (promArr) {
- return new TypesonPromise(function (typesonResolve, typesonReject) {
- // eslint-disable-next-line promise/catch-or-return
- Promise[meth](promArr.map(function (prom) {
- return prom && prom.constructor && prom.constructor.__typeson__type__ === 'TypesonPromise' ? prom.p : prom;
- })).then(typesonResolve, typesonReject);
- });
- };
- });
-
- var _ref = {},
- toStr = _ref.toString,
- hasOwn = {}.hasOwnProperty,
- getProto = Object.getPrototypeOf,
- fnToString = hasOwn.toString;
- /**
- * Second argument not in use internally, but provided for utility.
- * @param {Any} v
- * @param {boolean} catchCheck
- * @returns {boolean}
- */
-
- function isThenable(v, catchCheck) {
- return isObject(v) && typeof v.then === 'function' && (!catchCheck || typeof v["catch"] === 'function');
- }
- /**
- *
- * @param {Any} val
- * @returns {string}
- */
-
-
- function toStringTag(val) {
- return toStr.call(val).slice(8, -1);
- }
- /**
- * This function is dependent on both constructors
- * being identical so any minimization is expected of both.
- * @param {Any} a
- * @param {function} b
- * @returns {boolean}
- */
-
-
- function hasConstructorOf(a, b) {
- if (!a || _typeof(a) !== 'object') {
- return false;
- }
-
- var proto = getProto(a);
-
- if (!proto) {
- return b === null;
- }
-
- var Ctor = hasOwn.call(proto, 'constructor') && proto.constructor;
-
- if (typeof Ctor !== 'function') {
- return b === null;
- }
-
- if (b === Ctor) {
- return true;
- }
-
- if (b !== null && fnToString.call(Ctor) === fnToString.call(b)) {
- return true;
- }
-
- if (typeof b === 'function' && typeof Ctor.__typeson__type__ === 'string' && Ctor.__typeson__type__ === b.__typeson__type__) {
- return true;
- }
-
- return false;
- }
- /**
- *
- * @param {Any} val
- * @returns {boolean}
- */
-
-
- function isPlainObject(val) {
- // Mirrors jQuery's
- if (!val || toStringTag(val) !== 'Object') {
- return false;
- }
-
- var proto = getProto(val);
-
- if (!proto) {
- // `Object.create(null)`
- return true;
- }
-
- return hasConstructorOf(val, Object);
- }
- /**
- *
- * @param {Any} val
- * @returns {boolean}
- */
-
-
- function isUserObject(val) {
- if (!val || toStringTag(val) !== 'Object') {
- return false;
- }
-
- var proto = getProto(val);
-
- if (!proto) {
- // `Object.create(null)`
- return true;
- }
-
- return hasConstructorOf(val, Object) || isUserObject(proto);
- }
- /**
- *
- * @param {Any} v
- * @returns {boolean}
- */
-
-
- function isObject(v) {
- return v && _typeof(v) === 'object';
- }
- /**
- *
- * @param {string} keyPathComponent
- * @returns {string}
- */
-
-
- function escapeKeyPathComponent(keyPathComponent) {
- return keyPathComponent.replace(/~/g, '~0').replace(/\./g, '~1');
- }
- /**
- *
- * @param {string} keyPathComponent
- * @returns {string}
- */
-
-
- function unescapeKeyPathComponent(keyPathComponent) {
- return keyPathComponent.replace(/~1/g, '.').replace(/~0/g, '~');
- }
- /**
- * @param {PlainObject|GenericArray} obj
- * @param {string} keyPath
- * @returns {Any}
- */
-
-
- function getByKeyPath(obj, keyPath) {
- if (keyPath === '') {
- return obj;
- }
-
- var period = keyPath.indexOf('.');
-
- if (period > -1) {
- var innerObj = obj[unescapeKeyPathComponent(keyPath.slice(0, period))];
- return innerObj === undefined ? undefined : getByKeyPath(innerObj, keyPath.slice(period + 1));
- }
-
- return obj[unescapeKeyPathComponent(keyPath)];
- }
- /**
- *
- * @param {PlainObject} obj
- * @param {string} keyPath
- * @param {Any} value
- * @returns {Any}
- */
-
-
- function setAtKeyPath(obj, keyPath, value) {
- if (keyPath === '') {
- return value;
- }
-
- var period = keyPath.indexOf('.');
-
- if (period > -1) {
- var innerObj = obj[unescapeKeyPathComponent(keyPath.slice(0, period))];
- return setAtKeyPath(innerObj, keyPath.slice(period + 1), value);
- }
-
- obj[unescapeKeyPathComponent(keyPath)] = value;
- return obj;
- }
- /**
- *
- * @param {external:JSON} value
- * @returns {"null"|"array"|"undefined"|"boolean"|"number"|"string"|
- * "object"|"symbol"}
- */
-
-
- function getJSONType(value) {
- return value === null ? 'null' : Array.isArray(value) ? 'array' : _typeof(value);
- }
-
- var keys = Object.keys,
- isArray = Array.isArray,
- hasOwn$1 = {}.hasOwnProperty,
- internalStateObjPropsToIgnore = ['type', 'replaced', 'iterateIn', 'iterateUnsetNumeric'];
- /**
- * Handle plain object revivers first so reference setting can use
- * revived type (e.g., array instead of object); assumes revived
- * has same structure or will otherwise break subsequent references.
- * @param {PlainObjectType} a
- * @param {PlainObjectType} b
- * @returns {1|-1|boolean}
- */
-
- function nestedPathsFirst(a, b) {
- if (a.keypath === '') {
- return -1;
- }
-
- var as = a.keypath.match(/\./g) || 0;
- var bs = b.keypath.match(/\./g) || 0;
-
- if (as) {
- as = as.length;
- }
-
- if (bs) {
- bs = bs.length;
- }
-
- return as > bs ? -1 : as < bs ? 1 : a.keypath < b.keypath ? -1 : a.keypath > b.keypath;
- }
- /**
- * An instance of this class can be used to call `stringify()` and `parse()`.
- * Typeson resolves cyclic references by default. Can also be extended to
- * support custom types using the register() method.
- *
- * @class
- * @param {{cyclic: boolean}} [options] - if cyclic (default true),
- * cyclic references will be handled gracefully.
- */
-
-
- var Typeson =
- /*#__PURE__*/
- function () {
- function Typeson(options) {
- _classCallCheck(this, Typeson);
-
- this.options = options; // Replacers signature: replace (value). Returns falsy if not
- // replacing. Otherwise ['Date', value.getTime()]
-
- this.plainObjectReplacers = [];
- this.nonplainObjectReplacers = []; // Revivers: [{type => reviver}, {plain: boolean}].
- // Sample: [{'Date': value => new Date(value)}, {plain: false}]
-
- this.revivers = {};
- /** Types registered via `register()`. */
-
- this.types = {};
- }
- /**
- * @typedef {null|boolean|number|string|GenericArray|PlainObject} JSON
- */
-
- /**
- * @callback JSONReplacer
- * @param {""|string} key
- * @param {JSON} value
- * @returns {number|string|boolean|null|PlainObject|undefined}
- * @see https://developer.mozilla.org/en-US/docs/Web/JavaScript/Reference/Global_Objects/JSON/stringify#The%20replacer%20parameter
- */
-
- /**
- * Serialize given object to Typeson.
- * Initial arguments work identical to those of `JSON.stringify`.
- * The `replacer` argument has nothing to do with our replacers.
- * @param {Any} obj
- * @param {JSONReplacer|string[]} replacer
- * @param {number|string} space
- * @param {object} opts
- * @returns {string|Promise} Promise resolves to a string
- */
-
-
- _createClass(Typeson, [{
- key: "stringify",
- value: function stringify(obj, replacer, space, opts) {
- opts = _objectSpread2({}, this.options, {}, opts, {
- stringification: true
- });
- var encapsulated = this.encapsulate(obj, null, opts);
-
- if (isArray(encapsulated)) {
- return JSON.stringify(encapsulated[0], replacer, space);
- }
-
- return encapsulated.then(function (res) {
- return JSON.stringify(res, replacer, space);
- });
- }
- /**
- * Also sync but throws on non-sync result.
- * @param {Any} obj
- * @param {JSONReplacer|string[]} replacer
- * @param {number|string} space
- * @param {object} opts
- * @returns {string}
- */
-
- }, {
- key: "stringifySync",
- value: function stringifySync(obj, replacer, space, opts) {
- return this.stringify(obj, replacer, space, _objectSpread2({
- throwOnBadSyncType: true
- }, opts, {
- sync: true
- }));
- }
- /**
- *
- * @param {Any} obj
- * @param {JSONReplacer|string[]} replacer
- * @param {number|string} space
- * @param {object} opts
- * @returns {Promise<string>}
- */
-
- }, {
- key: "stringifyAsync",
- value: function stringifyAsync(obj, replacer, space, opts) {
- return this.stringify(obj, replacer, space, _objectSpread2({
- throwOnBadSyncType: true
- }, opts, {
- sync: false
- }));
- }
- /**
- * Parse Typeson back into an obejct.
- * Initial arguments works identical to those of `JSON.parse()`.
- * @param {string} text
- * @param {function} reviver This JSON reviver has nothing to do with
- * our revivers.
- * @param {object} opts
- * @returns {external:JSON}
- */
-
- }, {
- key: "parse",
- value: function parse(text, reviver, opts) {
- opts = _objectSpread2({}, this.options, {}, opts, {
- parse: true
- });
- return this.revive(JSON.parse(text, reviver), opts);
- }
- /**
- * Also sync but throws on non-sync result.
- * @param {string} text
- * @param {function} reviver This JSON reviver has nothing to do with
- * our revivers.
- * @param {object} opts
- * @returns {external:JSON}
- */
-
- }, {
- key: "parseSync",
- value: function parseSync(text, reviver, opts) {
- return this.parse(text, reviver, _objectSpread2({
- throwOnBadSyncType: true
- }, opts, {
- sync: true
- }));
- }
- /**
- * @param {string} text
- * @param {function} reviver This JSON reviver has nothing to do with
- * our revivers.
- * @param {object} opts
- * @returns {Promise} Resolves to `external:JSON`
- */
-
- }, {
- key: "parseAsync",
- value: function parseAsync(text, reviver, opts) {
- return this.parse(text, reviver, _objectSpread2({
- throwOnBadSyncType: true
- }, opts, {
- sync: false
- }));
- }
- /**
- *
- * @param {Any} obj
- * @param {object} stateObj
- * @param {object} [opts={}]
- * @returns {string[]|false}
- */
-
- }, {
- key: "specialTypeNames",
- value: function specialTypeNames(obj, stateObj) {
- var opts = arguments.length > 2 && arguments[2] !== undefined ? arguments[2] : {};
- opts.returnTypeNames = true;
- return this.encapsulate(obj, stateObj, opts);
- }
- /**
- *
- * @param {Any} obj
- * @param {PlainObject} stateObj
- * @param {PlainObject} [opts={}]
- * @returns {Promise|GenericArray|PlainObject|string|false}
- */
-
- }, {
- key: "rootTypeName",
- value: function rootTypeName(obj, stateObj) {
- var opts = arguments.length > 2 && arguments[2] !== undefined ? arguments[2] : {};
- opts.iterateNone = true;
- return this.encapsulate(obj, stateObj, opts);
- }
- /**
- * Encapsulate a complex object into a plain Object by replacing
- * registered types with plain objects representing the types data.
- *
- * This method is used internally by `Typeson.stringify()`.
- * @param {Any} obj - Object to encapsulate.
- * @param {PlainObject} stateObj
- * @param {PlainObject} opts
- * @returns {Promise|GenericArray|PlainObject|string|false}
- */
-
- }, {
- key: "encapsulate",
- value: function encapsulate(obj, stateObj, opts) {
- opts = _objectSpread2({
- sync: true
- }, this.options, {}, opts);
- var _opts = opts,
- sync = _opts.sync;
- var that = this,
- types = {},
- refObjs = [],
- // For checking cyclic references
- refKeys = [],
- // For checking cyclic references
- promisesDataRoot = []; // Clone the object deeply while at the same time replacing any
- // special types or cyclic reference:
-
- var cyclic = 'cyclic' in opts ? opts.cyclic : true;
- var _opts2 = opts,
- encapsulateObserver = _opts2.encapsulateObserver;
-
- var ret = _encapsulate('', obj, cyclic, stateObj || {}, promisesDataRoot);
- /**
- *
- * @param {Any} ret
- * @returns {GenericArray|PlainObject|string|false}
- */
-
-
- function finish(ret) {
- // Add `$types` to result only if we ever bumped into a
- // special type (or special case where object has own `$types`)
- var typeNames = Object.values(types);
-
- if (opts.iterateNone) {
- if (typeNames.length) {
- return typeNames[0];
- }
-
- return Typeson.getJSONType(ret);
- }
-
- if (typeNames.length) {
- if (opts.returnTypeNames) {
- return _toConsumableArray(new Set(typeNames));
- } // Special if array (or a primitive) was serialized
- // because JSON would ignore custom `$types` prop on it
-
-
- if (!ret || !isPlainObject(ret) || // Also need to handle if this is an object with its
- // own `$types` property (to avoid ambiguity)
- hasOwn$1.call(ret, '$types')) {
- ret = {
- $: ret,
- $types: {
- $: types
- }
- };
- } else {
- ret.$types = types;
- } // No special types
-
- } else if (isObject(ret) && hasOwn$1.call(ret, '$types')) {
- ret = {
- $: ret,
- $types: true
- };
- }
-
- if (opts.returnTypeNames) {
- return false;
- }
-
- return ret;
- }
- /**
- *
- * @param {Any} ret
- * @param {GenericArray} promisesData
- * @returns {Promise<Any>}
- */
-
-
- function checkPromises(_x, _x2) {
- return _checkPromises.apply(this, arguments);
- }
- /**
- *
- * @param {object} stateObj
- * @param {object} ownKeysObj
- * @param {function} cb
- * @returns {undefined}
- */
-
-
- function _checkPromises() {
- _checkPromises = _asyncToGenerator(
- /*#__PURE__*/
- regeneratorRuntime.mark(function _callee2(ret, promisesData) {
- var promResults;
- return regeneratorRuntime.wrap(function _callee2$(_context2) {
- while (1) {
- switch (_context2.prev = _context2.next) {
- case 0:
- _context2.next = 2;
- return Promise.all(promisesData.map(function (pd) {
- return pd[1].p;
- }));
-
- case 2:
- promResults = _context2.sent;
- _context2.next = 5;
- return Promise.all(promResults.map(
- /*#__PURE__*/
- function () {
- var _ref = _asyncToGenerator(
- /*#__PURE__*/
- regeneratorRuntime.mark(function _callee(promResult) {
- var newPromisesData, _promisesData$splice, _promisesData$splice2, prData, _prData, keyPath, cyclic, stateObj, parentObj, key, detectedType, encaps, isTypesonPromise, encaps2;
-
- return regeneratorRuntime.wrap(function _callee$(_context) {
- while (1) {
- switch (_context.prev = _context.next) {
- case 0:
- newPromisesData = [];
- _promisesData$splice = promisesData.splice(0, 1), _promisesData$splice2 = _slicedToArray(_promisesData$splice, 1), prData = _promisesData$splice2[0];
- _prData = _slicedToArray(prData, 7), keyPath = _prData[0], cyclic = _prData[2], stateObj = _prData[3], parentObj = _prData[4], key = _prData[5], detectedType = _prData[6];
- encaps = _encapsulate(keyPath, promResult, cyclic, stateObj, newPromisesData, true, detectedType);
- isTypesonPromise = hasConstructorOf(encaps, TypesonPromise); // Handle case where an embedded custom type itself
- // returns a `Typeson.Promise`
-
- if (!(keyPath && isTypesonPromise)) {
- _context.next = 11;
- break;
- }
-
- _context.next = 8;
- return encaps.p;
-
- case 8:
- encaps2 = _context.sent;
- parentObj[key] = encaps2;
- return _context.abrupt("return", checkPromises(ret, newPromisesData));
-
- case 11:
- if (keyPath) {
- parentObj[key] = encaps;
- } else if (isTypesonPromise) {
- ret = encaps.p;
- } else {
- // If this is itself a `Typeson.Promise` (because the
- // original value supplied was a `Promise` or
- // because the supplied custom type value resolved
- // to one), returning it below will be fine since
- // a `Promise` is expected anyways given current
- // config (and if not a `Promise`, it will be ready
- // as the resolve value)
- ret = encaps;
- }
-
- return _context.abrupt("return", checkPromises(ret, newPromisesData));
-
- case 13:
- case "end":
- return _context.stop();
- }
- }
- }, _callee);
- }));
-
- return function (_x3) {
- return _ref.apply(this, arguments);
- };
- }()));
-
- case 5:
- return _context2.abrupt("return", ret);
-
- case 6:
- case "end":
- return _context2.stop();
- }
- }
- }, _callee2);
- }));
- return _checkPromises.apply(this, arguments);
- }
-
- function _adaptBuiltinStateObjectProperties(stateObj, ownKeysObj, cb) {
- Object.assign(stateObj, ownKeysObj);
- var vals = internalStateObjPropsToIgnore.map(function (prop) {
- var tmp = stateObj[prop];
- delete stateObj[prop];
- return tmp;
- }); // eslint-disable-next-line callback-return
-
- cb();
- internalStateObjPropsToIgnore.forEach(function (prop, i) {
- stateObj[prop] = vals[i];
- });
- }
- /**
- *
- * @param {string} keypath
- * @param {Any} value
- * @param {boolean} cyclic
- * @param {PlainObject} stateObj
- * @param {boolean} promisesData
- * @param {boolean} resolvingTypesonPromise
- * @param {string} detectedType
- * @returns {Any}
- */
-
-
- function _encapsulate(keypath, value, cyclic, stateObj, promisesData, resolvingTypesonPromise, detectedType) {
- var ret;
- var observerData = {};
-
- var $typeof = _typeof(value);
-
- var runObserver = encapsulateObserver ? function (obj) {
- var type = detectedType || stateObj.type || Typeson.getJSONType(value);
- encapsulateObserver(Object.assign(obj || observerData, {
- keypath: keypath,
- value: value,
- cyclic: cyclic,
- stateObj: stateObj,
- promisesData: promisesData,
- resolvingTypesonPromise: resolvingTypesonPromise,
- awaitingTypesonPromise: hasConstructorOf(value, TypesonPromise)
- }, {
- type: type
- }));
- } : null;
-
- if (['string', 'boolean', 'number', 'undefined'].includes($typeof)) {
- if (value === undefined || $typeof === 'number' && (isNaN(value) || value === -Infinity || value === Infinity)) {
- if (stateObj.replaced) {
- ret = value;
- } else {
- ret = replace(keypath, value, stateObj, promisesData, false, resolvingTypesonPromise, runObserver);
- }
-
- if (ret !== value) {
- observerData = {
- replaced: ret
- };
- }
- } else {
- ret = value;
- }
-
- if (runObserver) {
- runObserver();
- }
-
- return ret;
- }
-
- if (value === null) {
- if (runObserver) {
- runObserver();
- }
-
- return value;
- }
-
- if (cyclic && !stateObj.iterateIn && !stateObj.iterateUnsetNumeric && value && _typeof(value) === 'object') {
- // Options set to detect cyclic references and be able
- // to rewrite them.
- var refIndex = refObjs.indexOf(value);
-
- if (refIndex < 0) {
- if (cyclic === true) {
- refObjs.push(value);
- refKeys.push(keypath);
- }
- } else {
- types[keypath] = '#';
-
- if (runObserver) {
- runObserver({
- cyclicKeypath: refKeys[refIndex]
- });
- }
-
- return '#' + refKeys[refIndex];
- }
- }
-
- var isPlainObj = isPlainObject(value);
- var isArr = isArray(value);
- var replaced = // Running replace will cause infinite loop as will test
- // positive again
- (isPlainObj || isArr) && (!that.plainObjectReplacers.length || stateObj.replaced) || stateObj.iterateIn ? // Optimization: if plain object and no plain-object
- // replacers, don't try finding a replacer
- value : replace(keypath, value, stateObj, promisesData, isPlainObj || isArr, null, runObserver);
- var clone;
-
- if (replaced !== value) {
- ret = replaced;
- observerData = {
- replaced: replaced
- };
- } else {
- // eslint-disable-next-line no-lonely-if
- if (keypath === '' && hasConstructorOf(value, TypesonPromise)) {
- promisesData.push([keypath, value, cyclic, stateObj, undefined, undefined, stateObj.type]);
- ret = value;
- } else if (isArr && stateObj.iterateIn !== 'object' || stateObj.iterateIn === 'array') {
- clone = new Array(value.length);
- observerData = {
- clone: clone
- };
- } else if (!['function', 'symbol'].includes(_typeof(value)) && !('toJSON' in value) && !hasConstructorOf(value, TypesonPromise) && !hasConstructorOf(value, Promise) && !hasConstructorOf(value, ArrayBuffer) || isPlainObj || stateObj.iterateIn === 'object') {
- clone = {};
-
- if (stateObj.addLength) {
- clone.length = value.length;
- }
-
- observerData = {
- clone: clone
- };
- } else {
- ret = value; // Only clone vanilla objects and arrays
- }
- }
-
- if (runObserver) {
- runObserver();
- }
-
- if (opts.iterateNone) {
- return clone || ret;
- }
-
- if (!clone) {
- return ret;
- } // Iterate object or array
-
-
- if (stateObj.iterateIn) {
- var _loop = function _loop(key) {
- var ownKeysObj = {
- ownKeys: hasOwn$1.call(value, key)
- };
-
- _adaptBuiltinStateObjectProperties(stateObj, ownKeysObj, function () {
- var kp = keypath + (keypath ? '.' : '') + escapeKeyPathComponent(key);
-
- var val = _encapsulate(kp, value[key], Boolean(cyclic), stateObj, promisesData, resolvingTypesonPromise);
-
- if (hasConstructorOf(val, TypesonPromise)) {
- promisesData.push([kp, val, Boolean(cyclic), stateObj, clone, key, stateObj.type]);
- } else if (val !== undefined) {
- clone[key] = val;
- }
- });
- };
-
- // eslint-disable-next-line guard-for-in
- for (var key in value) {
- _loop(key);
- }
-
- if (runObserver) {
- runObserver({
- endIterateIn: true,
- end: true
- });
- }
- } else {
- // Note: Non-indexes on arrays won't survive stringify so
- // somewhat wasteful for arrays, but so too is iterating
- // all numeric indexes on sparse arrays when not wanted
- // or filtering own keys for positive integers
- keys(value).forEach(function (key) {
- var kp = keypath + (keypath ? '.' : '') + escapeKeyPathComponent(key);
- var ownKeysObj = {
- ownKeys: true
- };
-
- _adaptBuiltinStateObjectProperties(stateObj, ownKeysObj, function () {
- var val = _encapsulate(kp, value[key], Boolean(cyclic), stateObj, promisesData, resolvingTypesonPromise);
-
- if (hasConstructorOf(val, TypesonPromise)) {
- promisesData.push([kp, val, Boolean(cyclic), stateObj, clone, key, stateObj.type]);
- } else if (val !== undefined) {
- clone[key] = val;
- }
- });
- });
-
- if (runObserver) {
- runObserver({
- endIterateOwn: true,
- end: true
- });
- }
- } // Iterate array for non-own numeric properties (we can't
- // replace the prior loop though as it iterates non-integer
- // keys)
-
-
- if (stateObj.iterateUnsetNumeric) {
- var vl = value.length;
-
- var _loop2 = function _loop2(i) {
- if (!(i in value)) {
- // No need to escape numeric
- var kp = keypath + (keypath ? '.' : '') + i;
- var ownKeysObj = {
- ownKeys: false
- };
-
- _adaptBuiltinStateObjectProperties(stateObj, ownKeysObj, function () {
- var val = _encapsulate(kp, undefined, Boolean(cyclic), stateObj, promisesData, resolvingTypesonPromise);
-
- if (hasConstructorOf(val, TypesonPromise)) {
- promisesData.push([kp, val, Boolean(cyclic), stateObj, clone, i, stateObj.type]);
- } else if (val !== undefined) {
- clone[i] = val;
- }
- });
- }
- };
-
- for (var i = 0; i < vl; i++) {
- _loop2(i);
- }
-
- if (runObserver) {
- runObserver({
- endIterateUnsetNumeric: true,
- end: true
- });
- }
- }
-
- return clone;
- }
- /**
- *
- * @param {string} keypath
- * @param {Any} value
- * @param {PlainObject} stateObj
- * @param {GenericArray} promisesData
- * @param {boolean} plainObject
- * @param {boolean} resolvingTypesonPromise
- * @param {function} [runObserver]
- * @returns {*}
- */
-
-
- function replace(keypath, value, stateObj, promisesData, plainObject, resolvingTypesonPromise, runObserver) {
- // Encapsulate registered types
- var replacers = plainObject ? that.plainObjectReplacers : that.nonplainObjectReplacers;
- var i = replacers.length;
-
- while (i--) {
- var replacer = replacers[i];
-
- if (replacer.test(value, stateObj)) {
- var type = replacer.type;
-
- if (that.revivers[type]) {
- // Record the type only if a corresponding reviver
- // exists. This is to support specs where only
- // replacement is done.
- // For example, ensuring deep cloning of the object,
- // or replacing a type to its equivalent without
- // the need to revive it.
- var existing = types[keypath]; // type can comprise an array of types (see test
- // "should support intermediate types")
-
- types[keypath] = existing ? [type].concat(existing) : type;
- }
-
- Object.assign(stateObj, {
- type: type,
- replaced: true
- });
-
- if ((sync || !replacer.replaceAsync) && !replacer.replace) {
- if (runObserver) {
- runObserver({
- typeDetected: true
- });
- }
-
- return _encapsulate(keypath, value, cyclic && 'readonly', stateObj, promisesData, resolvingTypesonPromise, type);
- }
-
- if (runObserver) {
- runObserver({
- replacing: true
- });
- } // Now, also traverse the result in case it contains its
- // own types to replace
-
-
- var replaceMethod = sync || !replacer.replaceAsync ? 'replace' : 'replaceAsync';
- return _encapsulate(keypath, replacer[replaceMethod](value, stateObj), cyclic && 'readonly', stateObj, promisesData, resolvingTypesonPromise, type);
- }
- }
-
- return value;
- }
-
- return promisesDataRoot.length ? sync && opts.throwOnBadSyncType ? function () {
- throw new TypeError('Sync method requested but async result obtained');
- }() : Promise.resolve(checkPromises(ret, promisesDataRoot)).then(finish) : !sync && opts.throwOnBadSyncType ? function () {
- throw new TypeError('Async method requested but sync result obtained');
- }() // If this is a synchronous request for stringification, yet
- // a promise is the result, we don't want to resolve leading
- // to an async result, so we return an array to avoid
- // ambiguity
- : opts.stringification && sync ? [finish(ret)] : sync ? finish(ret) : Promise.resolve(finish(ret));
- }
- /**
- * Also sync but throws on non-sync result.
- * @param {*} obj
- * @param {object} stateObj
- * @param {object} opts
- * @returns {*}
- */
-
- }, {
- key: "encapsulateSync",
- value: function encapsulateSync(obj, stateObj, opts) {
- return this.encapsulate(obj, stateObj, _objectSpread2({
- throwOnBadSyncType: true
- }, opts, {
- sync: true
- }));
- }
- /**
- * @param {*} obj
- * @param {object} stateObj
- * @param {object} opts
- * @returns {*}
- */
-
- }, {
- key: "encapsulateAsync",
- value: function encapsulateAsync(obj, stateObj, opts) {
- return this.encapsulate(obj, stateObj, _objectSpread2({
- throwOnBadSyncType: true
- }, opts, {
- sync: false
- }));
- }
- /**
- * Revive an encapsulated object.
- * This method is used internally by `Typeson.parse()`.
- * @param {object} obj - Object to revive. If it has `$types` member, the
- * properties that are listed there will be replaced with its true type
- * instead of just plain objects.
- * @param {object} opts
- * @throws TypeError If mismatch between sync/async type and result
- * @returns {Promise|*} If async, returns a Promise that resolves to `*`
- */
-
- }, {
- key: "revive",
- value: function revive(obj, opts) {
- var types = obj && obj.$types; // No type info added. Revival not needed.
-
- if (!types) {
- return obj;
- } // Object happened to have own `$types` property but with
- // no actual types, so we unescape and return that object
-
-
- if (types === true) {
- return obj.$;
- }
-
- opts = _objectSpread2({
- sync: true
- }, this.options, {}, opts);
- var _opts3 = opts,
- sync = _opts3.sync;
- var keyPathResolutions = [];
- var stateObj = {};
- var ignore$Types = true; // Special when root object is not a trivial Object, it will
- // be encapsulated in `$`. It will also be encapsulated in
- // `$` if it has its own `$` property to avoid ambiguity
-
- if (types.$ && isPlainObject(types.$)) {
- obj = obj.$;
- types = types.$;
- ignore$Types = false;
- }
-
- var that = this;
- /**
- * @callback RevivalReducer
- * @param {Any} value
- * @param {string} type
- * @returns {Any}
- */
-
- /**
- *
- * @param {string} type
- * @param {Any} val
- * @returns {[type]} [description]
- */
-
- function executeReviver(type, val) {
- var _ref2 = that.revivers[type] || [],
- _ref3 = _slicedToArray(_ref2, 1),
- reviver = _ref3[0];
-
- if (!reviver) {
- throw new Error('Unregistered type: ' + type);
- } // Only `sync` expected here, as problematic async would
- // be missing both `reviver` and `reviverAsync`, and
- // encapsulation shouldn't have added types, so
- // should have made an early exit
-
-
- if (sync && !('revive' in reviver)) {
- // Just return value as is
- return val;
- }
-
- return reviver[sync && reviver.revive ? 'revive' : !sync && reviver.reviveAsync ? 'reviveAsync' : 'revive'](val, stateObj);
- }
- /**
- *
- * @returns {void|TypesonPromise<void>}
- */
-
-
- function revivePlainObjects() {
- // const references = [];
- // const reviveTypes = [];
- var plainObjectTypes = [];
- Object.entries(types).forEach(function (_ref4) {
- var _ref5 = _slicedToArray(_ref4, 2),
- keypath = _ref5[0],
- type = _ref5[1];
-
- if (type === '#') {
- /*
- references.push({
- keypath,
- reference: getByKeyPath(obj, keypath)
- });
- */
- return;
- }
-
- [].concat(type).forEach(function (type) {
- var _ref6 = that.revivers[type] || [null, {}],
- _ref7 = _slicedToArray(_ref6, 2),
- plain = _ref7[1].plain;
-
- if (!plain) {
- // reviveTypes.push({keypath, type});
- return;
- }
-
- plainObjectTypes.push({
- keypath: keypath,
- type: type
- });
- delete types[keypath]; // Avoid repeating
- });
- });
-
- if (!plainObjectTypes.length) {
- return undefined;
- } // console.log(plainObjectTypes.sort(nestedPathsFirst));
-
- /**
- * @typedef {PlainObject} PlainObjectType
- * @property {string} keypath
- * @property {string} type
- */
-
-
- return plainObjectTypes.sort(nestedPathsFirst).reduce(function reducer(possibleTypesonPromise, _ref8) {
- var keypath = _ref8.keypath,
- type = _ref8.type;
-
- if (isThenable(possibleTypesonPromise)) {
- return possibleTypesonPromise.then(function (val) {
- return reducer(val, {
- keypath: keypath,
- type: type
- });
- });
- } // console.log('obj', JSON.stringify(keypath), obj);
-
-
- var val = getByKeyPath(obj, keypath);
- val = executeReviver(type, val);
-
- if (hasConstructorOf(val, TypesonPromise)) {
- return val.then(function (v) {
- var newVal = setAtKeyPath(obj, keypath, v);
-
- if (newVal === v) {
- obj = newVal;
- }
-
- return undefined;
- });
- }
-
- var newVal = setAtKeyPath(obj, keypath, val);
-
- if (newVal === val) {
- obj = newVal;
- }
-
- return undefined;
- }, undefined // This argument must be explicit
- ); // references.forEach(({keypath, reference}) => {});
- // reviveTypes.sort(nestedPathsFirst).forEach(() => {});
- }
-
- var revivalPromises = [];
- /**
- *
- * @param {string} keypath
- * @param {Any} value
- * @param {?(Array|object)} target
- * @param {Array|object} [clone]
- * @param {string} [key]
- * @returns {Any}
- */
-
- function _revive(keypath, value, target, clone, key) {
- if (ignore$Types && keypath === '$types') {
- return undefined;
- }
-
- var type = types[keypath];
- var isArr = isArray(value);
-
- if (isArr || isPlainObject(value)) {
- var _clone = isArr ? new Array(value.length) : {}; // Iterate object or array
-
-
- keys(value).forEach(function (k) {
- var val = _revive(keypath + (keypath ? '.' : '') + escapeKeyPathComponent(k), value[k], target || _clone, _clone, k);
-
- var set = function set(v) {
- if (hasConstructorOf(v, Undefined)) {
- _clone[k] = undefined;
- } else if (v !== undefined) {
- _clone[k] = v;
- }
-
- return v;
- };
-
- if (hasConstructorOf(val, TypesonPromise)) {
- revivalPromises.push(val.then(function (ret) {
- return set(ret);
- }));
- } else {
- set(val);
- }
- });
- value = _clone; // Try to resolve cyclic reference as soon as available
-
- while (keyPathResolutions.length) {
- var _keyPathResolutions$ = _slicedToArray(keyPathResolutions[0], 4),
- _target = _keyPathResolutions$[0],
- keyPath = _keyPathResolutions$[1],
- _clone2 = _keyPathResolutions$[2],
- k = _keyPathResolutions$[3];
-
- var val = getByKeyPath(_target, keyPath); // Typeson.Undefined not expected here as not cyclic or
- // `undefined`
-
- if (val !== undefined) {
- _clone2[k] = val;
- } else {
- break;
- }
-
- keyPathResolutions.splice(0, 1);
- }
- }
-
- if (!type) {
- return value;
- }
-
- if (type === '#') {
- var _ret = getByKeyPath(target, value.slice(1));
-
- if (_ret === undefined) {
- // Cyclic reference not yet available
- keyPathResolutions.push([target, value.slice(1), clone, key]);
- }
-
- return _ret;
- } // `type` can be an array here
-
-
- return [].concat(type).reduce(function reducer(val, typ) {
- if (hasConstructorOf(val, TypesonPromise)) {
- return val.then(function (v) {
- // TypesonPromise here too
- return reducer(v, typ);
- });
- }
-
- return executeReviver(typ, val);
- }, value);
- }
- /**
- *
- * @param {Any} retrn
- * @returns {undefined|Any}
- */
-
-
- function checkUndefined(retrn) {
- return hasConstructorOf(retrn, Undefined) ? undefined : retrn;
- }
-
- var possibleTypesonPromise = revivePlainObjects();
- var ret;
-
- if (hasConstructorOf(possibleTypesonPromise, TypesonPromise)) {
- ret = possibleTypesonPromise.then(function () {
- return obj;
- });
- } else {
- ret = _revive('', obj, null);
-
- if (revivalPromises.length) {
- // Ensure children resolved
- ret = TypesonPromise.resolve(ret).then(function (r) {
- return TypesonPromise.all([// May be a TypesonPromise or not
- r].concat(revivalPromises));
- }).then(function (_ref9) {
- var _ref10 = _slicedToArray(_ref9, 1),
- r = _ref10[0];
-
- return r;
- });
- }
- }
-
- return isThenable(ret) ? sync && opts.throwOnBadSyncType ? function () {
- throw new TypeError('Sync method requested but async result obtained');
- }() : hasConstructorOf(ret, TypesonPromise) ? ret.p.then(checkUndefined) : ret : !sync && opts.throwOnBadSyncType ? function () {
- throw new TypeError('Async method requested but sync result obtained');
- }() : sync ? checkUndefined(ret) : Promise.resolve(checkUndefined(ret));
- }
- /**
- * Also sync but throws on non-sync result.
- * @param {Any} obj
- * @param {object} opts
- * @returns {Any}
- */
-
- }, {
- key: "reviveSync",
- value: function reviveSync(obj, opts) {
- return this.revive(obj, _objectSpread2({
- throwOnBadSyncType: true
- }, opts, {
- sync: true
- }));
- }
- /**
- * @param {Any} obj
- * @param {object} opts
- * @returns {Promise} Resolves to `*`
- */
-
- }, {
- key: "reviveAsync",
- value: function reviveAsync(obj, opts) {
- return this.revive(obj, _objectSpread2({
- throwOnBadSyncType: true
- }, opts, {
- sync: false
- }));
- }
- /**
- * Register types.
- * For examples on how to use this method, see
- * {@link https://github.com/dfahlander/typeson-registry/tree/master/types}.
- * @param {object.<string,Function[]>[]} typeSpecSets - Types and
- * their functions [test, encapsulate, revive];
- * @param {object} opts
- * @returns {Typeson}
- */
-
- }, {
- key: "register",
- value: function register(typeSpecSets, opts) {
- opts = opts || {};
- [].concat(typeSpecSets).forEach(function R(typeSpec) {
- var _this = this;
-
- // Allow arrays of arrays of arrays...
- if (isArray(typeSpec)) {
- return typeSpec.map(function (typSpec) {
- return R.call(_this, typSpec);
- });
- }
-
- typeSpec && keys(typeSpec).forEach(function (typeId) {
- if (typeId === '#') {
- throw new TypeError('# cannot be used as a type name as it is reserved ' + 'for cyclic objects');
- } else if (Typeson.JSON_TYPES.includes(typeId)) {
- throw new TypeError('Plain JSON object types are reserved as type names');
- }
-
- var spec = typeSpec[typeId];
- var replacers = spec && spec.testPlainObjects ? this.plainObjectReplacers : this.nonplainObjectReplacers;
- var existingReplacer = replacers.filter(function (r) {
- return r.type === typeId;
- });
-
- if (existingReplacer.length) {
- // Remove existing spec and replace with this one.
- replacers.splice(replacers.indexOf(existingReplacer[0]), 1);
- delete this.revivers[typeId];
- delete this.types[typeId];
- }
-
- if (typeof spec === 'function') {
- // Support registering just a class without replacer/reviver
- var Class = spec;
- spec = {
- test: function test(x) {
- return x && x.constructor === Class;
- },
- replace: function replace(x) {
- return _objectSpread2({}, x);
- },
- revive: function revive(x) {
- return Object.assign(Object.create(Class.prototype), x);
- }
- };
- } else if (isArray(spec)) {
- var _spec = spec,
- _spec2 = _slicedToArray(_spec, 3),
- test = _spec2[0],
- replace = _spec2[1],
- revive = _spec2[2];
-
- spec = {
- test: test,
- replace: replace,
- revive: revive
- };
- }
-
- if (!spec || !spec.test) {
- return;
- }
-
- var replacerObj = {
- type: typeId,
- test: spec.test.bind(spec)
- };
-
- if (spec.replace) {
- replacerObj.replace = spec.replace.bind(spec);
- }
-
- if (spec.replaceAsync) {
- replacerObj.replaceAsync = spec.replaceAsync.bind(spec);
- }
-
- var start = typeof opts.fallback === 'number' ? opts.fallback : opts.fallback ? 0 : Infinity;
-
- if (spec.testPlainObjects) {
- this.plainObjectReplacers.splice(start, 0, replacerObj);
- } else {
- this.nonplainObjectReplacers.splice(start, 0, replacerObj);
- } // Todo: We might consider a testAsync type
-
-
- if (spec.revive || spec.reviveAsync) {
- var reviverObj = {};
-
- if (spec.revive) {
- reviverObj.revive = spec.revive.bind(spec);
- }
-
- if (spec.reviveAsync) {
- reviverObj.reviveAsync = spec.reviveAsync.bind(spec);
- }
-
- this.revivers[typeId] = [reviverObj, {
- plain: spec.testPlainObjects
- }];
- } // Record to be retrieved via public types property.
-
-
- this.types[typeId] = spec;
- }, this);
- }, this);
- return this;
- }
- }]);
-
- return Typeson;
- }();
- /**
- * We keep this function minimized so if using two instances of this
- * library, where one is minimized and one is not, it will still work
- * with `hasConstructorOf`.
- * @class
- */
-
-
- var Undefined = function Undefined() {
- _classCallCheck(this, Undefined);
- }; // eslint-disable-line space-before-blocks
-
-
- Undefined.__typeson__type__ = 'TypesonUndefined'; // The following provide classes meant to avoid clashes with other values
- // To insist `undefined` should be added
-
- Typeson.Undefined = Undefined; // To support async encapsulation/stringification
-
- Typeson.Promise = TypesonPromise; // Some fundamental type-checking utilities
-
- Typeson.isThenable = isThenable;
- Typeson.toStringTag = toStringTag;
- Typeson.hasConstructorOf = hasConstructorOf;
- Typeson.isObject = isObject;
- Typeson.isPlainObject = isPlainObject;
- Typeson.isUserObject = isUserObject;
- Typeson.escapeKeyPathComponent = escapeKeyPathComponent;
- Typeson.unescapeKeyPathComponent = unescapeKeyPathComponent;
- Typeson.getByKeyPath = getByKeyPath;
- Typeson.getJSONType = getJSONType;
- Typeson.JSON_TYPES = ['null', 'boolean', 'number', 'string', 'array', 'object'];
-
- return Typeson;
-
- })));
- });
-
- var structuredCloning = createCommonjsModule(function (module, exports) {
- !function(e,t){module.exports=t();}(commonjsGlobal,(function(){function _typeof$1(e){return (_typeof$1="function"==typeof Symbol&&"symbol"==typeof Symbol.iterator?function(e){return typeof e}:function(e){return e&&"function"==typeof Symbol&&e.constructor===Symbol&&e!==Symbol.prototype?"symbol":typeof e})(e)}function _classCallCheck$1(e,t){if(!(e instanceof t))throw new TypeError("Cannot call a class as a function")}function _defineProperties$1(e,t){for(var r=0;r<t.length;r++){var n=t[r];n.enumerable=n.enumerable||!1,n.configurable=!0,"value"in n&&(n.writable=!0),Object.defineProperty(e,n.key,n);}}function _defineProperty$1(e,t,r){return t in e?Object.defineProperty(e,t,{value:r,enumerable:!0,configurable:!0,writable:!0}):e[t]=r,e}function ownKeys$1(e,t){var r=Object.keys(e);if(Object.getOwnPropertySymbols){var n=Object.getOwnPropertySymbols(e);t&&(n=n.filter((function(t){return Object.getOwnPropertyDescriptor(e,t).enumerable}))),r.push.apply(r,n);}return r}function _toConsumableArray$1(e){return function _arrayWithoutHoles$1(e){if(Array.isArray(e))return _arrayLikeToArray$1(e)}(e)||function _iterableToArray$1(e){if("undefined"!=typeof Symbol&&Symbol.iterator in Object(e))return Array.from(e)}(e)||function _unsupportedIterableToArray$1(e,t){if(!e)return;if("string"==typeof e)return _arrayLikeToArray$1(e,t);var r=Object.prototype.toString.call(e).slice(8,-1);"Object"===r&&e.constructor&&(r=e.constructor.name);if("Map"===r||"Set"===r)return Array.from(e);if("Arguments"===r||/^(?:Ui|I)nt(?:8|16|32)(?:Clamped)?Array$/.test(r))return _arrayLikeToArray$1(e,t)}(e)||function _nonIterableSpread$1(){throw new TypeError("Invalid attempt to spread non-iterable instance.\nIn order to be iterable, non-array objects must have a [Symbol.iterator]() method.")}()}function _arrayLikeToArray$1(e,t){(null==t||t>e.length)&&(t=e.length);for(var r=0,n=new Array(t);r<t;r++)n[r]=e[r];return n}function _typeof(e){return (_typeof="function"==typeof Symbol&&"symbol"==typeof Symbol.iterator?function _typeof(e){return typeof e}:function _typeof(e){return e&&"function"==typeof Symbol&&e.constructor===Symbol&&e!==Symbol.prototype?"symbol":typeof e})(e)}function _classCallCheck(e,t){if(!(e instanceof t))throw new TypeError("Cannot call a class as a function")}function _defineProperties(e,t){for(var r=0;r<t.length;r++){var n=t[r];n.enumerable=n.enumerable||!1,n.configurable=!0,"value"in n&&(n.writable=!0),Object.defineProperty(e,n.key,n);}}function _defineProperty(e,t,r){return t in e?Object.defineProperty(e,t,{value:r,enumerable:!0,configurable:!0,writable:!0}):e[t]=r,e}function ownKeys(e,t){var r=Object.keys(e);if(Object.getOwnPropertySymbols){var n=Object.getOwnPropertySymbols(e);t&&(n=n.filter((function(t){return Object.getOwnPropertyDescriptor(e,t).enumerable}))),r.push.apply(r,n);}return r}function _objectSpread2(e){for(var t=1;t<arguments.length;t++){var r=null!=arguments[t]?arguments[t]:{};t%2?ownKeys(Object(r),!0).forEach((function(t){_defineProperty(e,t,r[t]);})):Object.getOwnPropertyDescriptors?Object.defineProperties(e,Object.getOwnPropertyDescriptors(r)):ownKeys(Object(r)).forEach((function(t){Object.defineProperty(e,t,Object.getOwnPropertyDescriptor(r,t));}));}return e}function _slicedToArray(e,t){return function _arrayWithHoles(e){if(Array.isArray(e))return e}(e)||function _iterableToArrayLimit(e,t){if("undefined"==typeof Symbol||!(Symbol.iterator in Object(e)))return;var r=[],n=!0,i=!1,o=void 0;try{for(var a,c=e[Symbol.iterator]();!(n=(a=c.next()).done)&&(r.push(a.value),!t||r.length!==t);n=!0);}catch(e){i=!0,o=e;}finally{try{n||null==c.return||c.return();}finally{if(i)throw o}}return r}(e,t)||_unsupportedIterableToArray(e,t)||function _nonIterableRest(){throw new TypeError("Invalid attempt to destructure non-iterable instance.\nIn order to be iterable, non-array objects must have a [Symbol.iterator]() method.")}()}function _toConsumableArray(e){return function _arrayWithoutHoles(e){if(Array.isArray(e))return _arrayLikeToArray(e)}(e)||function _iterableToArray(e){if("undefined"!=typeof Symbol&&Symbol.iterator in Object(e))return Array.from(e)}(e)||_unsupportedIterableToArray(e)||function _nonIterableSpread(){throw new TypeError("Invalid attempt to spread non-iterable instance.\nIn order to be iterable, non-array objects must have a [Symbol.iterator]() method.")}()}function _unsupportedIterableToArray(e,t){if(e){if("string"==typeof e)return _arrayLikeToArray(e,t);var r=Object.prototype.toString.call(e).slice(8,-1);return "Object"===r&&e.constructor&&(r=e.constructor.name),"Map"===r||"Set"===r?Array.from(e):"Arguments"===r||/^(?:Ui|I)nt(?:8|16|32)(?:Clamped)?Array$/.test(r)?_arrayLikeToArray(e,t):void 0}}function _arrayLikeToArray(e,t){(null==t||t>e.length)&&(t=e.length);for(var r=0,n=new Array(t);r<t;r++)n[r]=e[r];return n}var e=function TypesonPromise(e){_classCallCheck(this,TypesonPromise),this.p=new Promise(e);};e.__typeson__type__="TypesonPromise","undefined"!=typeof Symbol&&(e.prototype[Symbol.toStringTag]="TypesonPromise"),e.prototype.then=function(t,r){var n=this;return new e((function(e,i){n.p.then((function(r){e(t?t(r):r);})).catch((function(e){return r?r(e):Promise.reject(e)})).then(e,i);}))},e.prototype.catch=function(e){return this.then(null,e)},e.resolve=function(t){return new e((function(e){e(t);}))},e.reject=function(t){return new e((function(e,r){r(t);}))},["all","race"].forEach((function(t){e[t]=function(r){return new e((function(e,n){Promise[t](r.map((function(e){return e&&e.constructor&&"TypesonPromise"===e.constructor.__typeson__type__?e.p:e}))).then(e,n);}))};}));var t={}.toString,r={}.hasOwnProperty,n=Object.getPrototypeOf,i=r.toString;function isThenable(e,t){return isObject(e)&&"function"==typeof e.then&&(!t||"function"==typeof e.catch)}function toStringTag(e){return t.call(e).slice(8,-1)}function hasConstructorOf(e,t){if(!e||"object"!==_typeof(e))return !1;var o=n(e);if(!o)return null===t;var a=r.call(o,"constructor")&&o.constructor;return "function"!=typeof a?null===t:t===a||(null!==t&&i.call(a)===i.call(t)||"function"==typeof t&&"string"==typeof a.__typeson__type__&&a.__typeson__type__===t.__typeson__type__)}function isPlainObject(e){return !(!e||"Object"!==toStringTag(e))&&(!n(e)||hasConstructorOf(e,Object))}function isObject(e){return e&&"object"===_typeof(e)}function escapeKeyPathComponent(e){return e.replace(/~/g,"~0").replace(/\./g,"~1")}function unescapeKeyPathComponent(e){return e.replace(/~1/g,".").replace(/~0/g,"~")}function getByKeyPath(e,t){if(""===t)return e;var r=t.indexOf(".");if(r>-1){var n=e[unescapeKeyPathComponent(t.slice(0,r))];return void 0===n?void 0:getByKeyPath(n,t.slice(r+1))}return e[unescapeKeyPathComponent(t)]}function setAtKeyPath(e,t,r){if(""===t)return r;var n=t.indexOf(".");return n>-1?setAtKeyPath(e[unescapeKeyPathComponent(t.slice(0,n))],t.slice(n+1),r):(e[unescapeKeyPathComponent(t)]=r,e)}function _await(e,t,r){return r?t?t(e):e:(e&&e.then||(e=Promise.resolve(e)),t?e.then(t):e)}var o=Object.keys,a=Array.isArray,c={}.hasOwnProperty,u=["type","replaced","iterateIn","iterateUnsetNumeric"];function _async(e){return function(){for(var t=[],r=0;r<arguments.length;r++)t[r]=arguments[r];try{return Promise.resolve(e.apply(this,t))}catch(e){return Promise.reject(e)}}}function nestedPathsFirst(e,t){if(""===e.keypath)return -1;var r=e.keypath.match(/\./g)||0,n=t.keypath.match(/\./g)||0;return r&&(r=r.length),n&&(n=n.length),r>n?-1:r<n?1:e.keypath<t.keypath?-1:e.keypath>t.keypath}var s=function(){function Typeson(e){_classCallCheck(this,Typeson),this.options=e,this.plainObjectReplacers=[],this.nonplainObjectReplacers=[],this.revivers={},this.types={};}return function _createClass(e,t,r){return t&&_defineProperties(e.prototype,t),r&&_defineProperties(e,r),e}(Typeson,[{key:"stringify",value:function stringify(e,t,r,n){n=_objectSpread2(_objectSpread2(_objectSpread2({},this.options),n),{},{stringification:!0});var i=this.encapsulate(e,null,n);return a(i)?JSON.stringify(i[0],t,r):i.then((function(e){return JSON.stringify(e,t,r)}))}},{key:"stringifySync",value:function stringifySync(e,t,r,n){return this.stringify(e,t,r,_objectSpread2(_objectSpread2({throwOnBadSyncType:!0},n),{},{sync:!0}))}},{key:"stringifyAsync",value:function stringifyAsync(e,t,r,n){return this.stringify(e,t,r,_objectSpread2(_objectSpread2({throwOnBadSyncType:!0},n),{},{sync:!1}))}},{key:"parse",value:function parse(e,t,r){return r=_objectSpread2(_objectSpread2(_objectSpread2({},this.options),r),{},{parse:!0}),this.revive(JSON.parse(e,t),r)}},{key:"parseSync",value:function parseSync(e,t,r){return this.parse(e,t,_objectSpread2(_objectSpread2({throwOnBadSyncType:!0},r),{},{sync:!0}))}},{key:"parseAsync",value:function parseAsync(e,t,r){return this.parse(e,t,_objectSpread2(_objectSpread2({throwOnBadSyncType:!0},r),{},{sync:!1}))}},{key:"specialTypeNames",value:function specialTypeNames(e,t){var r=arguments.length>2&&void 0!==arguments[2]?arguments[2]:{};return r.returnTypeNames=!0,this.encapsulate(e,t,r)}},{key:"rootTypeName",value:function rootTypeName(e,t){var r=arguments.length>2&&void 0!==arguments[2]?arguments[2]:{};return r.iterateNone=!0,this.encapsulate(e,t,r)}},{key:"encapsulate",value:function encapsulate(t,r,n){var i=_async((function(t,r){return _await(Promise.all(r.map((function(e){return e[1].p}))),(function(n){return _await(Promise.all(n.map(_async((function(n){var o=!1,a=[],c=_slicedToArray(r.splice(0,1),1),u=_slicedToArray(c[0],7),s=u[0],f=u[2],l=u[3],p=u[4],y=u[5],v=u[6],b=_encapsulate(s,n,f,l,a,!0,v),d=hasConstructorOf(b,e);return function _invoke(e,t){var r=e();return r&&r.then?r.then(t):t(r)}((function(){if(s&&d)return _await(b.p,(function(e){return p[y]=e,o=!0,i(t,a)}))}),(function(e){return o?e:(s?p[y]=b:t=d?b.p:b,i(t,a))}))})))),(function(){return t}))}))})),s=(n=_objectSpread2(_objectSpread2({sync:!0},this.options),n)).sync,f=this,l={},p=[],y=[],v=[],b=!("cyclic"in n)||n.cyclic,d=n.encapsulateObserver,h=_encapsulate("",t,b,r||{},v);function finish(e){var t=Object.values(l);if(n.iterateNone)return t.length?t[0]:Typeson.getJSONType(e);if(t.length){if(n.returnTypeNames)return _toConsumableArray(new Set(t));e&&isPlainObject(e)&&!c.call(e,"$types")?e.$types=l:e={$:e,$types:{$:l}};}else isObject(e)&&c.call(e,"$types")&&(e={$:e,$types:!0});return !n.returnTypeNames&&e}function _adaptBuiltinStateObjectProperties(e,t,r){Object.assign(e,t);var n=u.map((function(t){var r=e[t];return delete e[t],r}));r(),u.forEach((function(t,r){e[t]=n[r];}));}function _encapsulate(t,r,i,u,s,v,b){var h,g={},m=_typeof(r),O=d?function(n){var o=b||u.type||Typeson.getJSONType(r);d(Object.assign(n||g,{keypath:t,value:r,cyclic:i,stateObj:u,promisesData:s,resolvingTypesonPromise:v,awaitingTypesonPromise:hasConstructorOf(r,e)},{type:o}));}:null;if(["string","boolean","number","undefined"].includes(m))return void 0===r||Number.isNaN(r)||r===Number.NEGATIVE_INFINITY||r===Number.POSITIVE_INFINITY?(h=u.replaced?r:replace(t,r,u,s,!1,v,O))!==r&&(g={replaced:h}):h=r,O&&O(),h;if(null===r)return O&&O(),r;if(i&&!u.iterateIn&&!u.iterateUnsetNumeric&&r&&"object"===_typeof(r)){var _=p.indexOf(r);if(!(_<0))return l[t]="#",O&&O({cyclicKeypath:y[_]}),"#"+y[_];!0===i&&(p.push(r),y.push(t));}var j,S=isPlainObject(r),T=a(r),w=(S||T)&&(!f.plainObjectReplacers.length||u.replaced)||u.iterateIn?r:replace(t,r,u,s,S||T,null,O);if(w!==r?(h=w,g={replaced:w}):""===t&&hasConstructorOf(r,e)?(s.push([t,r,i,u,void 0,void 0,u.type]),h=r):T&&"object"!==u.iterateIn||"array"===u.iterateIn?(j=new Array(r.length),g={clone:j}):(["function","symbol"].includes(_typeof(r))||"toJSON"in r||hasConstructorOf(r,e)||hasConstructorOf(r,Promise)||hasConstructorOf(r,ArrayBuffer))&&!S&&"object"!==u.iterateIn?h=r:(j={},u.addLength&&(j.length=r.length),g={clone:j}),O&&O(),n.iterateNone)return j||h;if(!j)return h;if(u.iterateIn){var A=function _loop(n){var o={ownKeys:c.call(r,n)};_adaptBuiltinStateObjectProperties(u,o,(function(){var o=t+(t?".":"")+escapeKeyPathComponent(n),a=_encapsulate(o,r[n],Boolean(i),u,s,v);hasConstructorOf(a,e)?s.push([o,a,Boolean(i),u,j,n,u.type]):void 0!==a&&(j[n]=a);}));};for(var P in r)A(P);O&&O({endIterateIn:!0,end:!0});}else o(r).forEach((function(n){var o=t+(t?".":"")+escapeKeyPathComponent(n);_adaptBuiltinStateObjectProperties(u,{ownKeys:!0},(function(){var t=_encapsulate(o,r[n],Boolean(i),u,s,v);hasConstructorOf(t,e)?s.push([o,t,Boolean(i),u,j,n,u.type]):void 0!==t&&(j[n]=t);}));})),O&&O({endIterateOwn:!0,end:!0});if(u.iterateUnsetNumeric){for(var I=r.length,C=function _loop2(n){if(!(n in r)){var o=t+(t?".":"")+n;_adaptBuiltinStateObjectProperties(u,{ownKeys:!1},(function(){var t=_encapsulate(o,void 0,Boolean(i),u,s,v);hasConstructorOf(t,e)?s.push([o,t,Boolean(i),u,j,n,u.type]):void 0!==t&&(j[n]=t);}));}},N=0;N<I;N++)C(N);O&&O({endIterateUnsetNumeric:!0,end:!0});}return j}function replace(e,t,r,n,i,o,a){for(var c=i?f.plainObjectReplacers:f.nonplainObjectReplacers,u=c.length;u--;){var p=c[u];if(p.test(t,r)){var y=p.type;if(f.revivers[y]){var v=l[e];l[e]=v?[y].concat(v):y;}return Object.assign(r,{type:y,replaced:!0}),!s&&p.replaceAsync||p.replace?(a&&a({replacing:!0}),_encapsulate(e,p[s||!p.replaceAsync?"replace":"replaceAsync"](t,r),b&&"readonly",r,n,o,y)):(a&&a({typeDetected:!0}),_encapsulate(e,t,b&&"readonly",r,n,o,y))}}return t}return v.length?s&&n.throwOnBadSyncType?function(){throw new TypeError("Sync method requested but async result obtained")}():Promise.resolve(i(h,v)).then(finish):!s&&n.throwOnBadSyncType?function(){throw new TypeError("Async method requested but sync result obtained")}():n.stringification&&s?[finish(h)]:s?finish(h):Promise.resolve(finish(h))}},{key:"encapsulateSync",value:function encapsulateSync(e,t,r){return this.encapsulate(e,t,_objectSpread2(_objectSpread2({throwOnBadSyncType:!0},r),{},{sync:!0}))}},{key:"encapsulateAsync",value:function encapsulateAsync(e,t,r){return this.encapsulate(e,t,_objectSpread2(_objectSpread2({throwOnBadSyncType:!0},r),{},{sync:!1}))}},{key:"revive",value:function revive(t,r){var n=t&&t.$types;if(!n)return t;if(!0===n)return t.$;var i=(r=_objectSpread2(_objectSpread2({sync:!0},this.options),r)).sync,c=[],u={},s=!0;n.$&&isPlainObject(n.$)&&(t=t.$,n=n.$,s=!1);var l=this;function executeReviver(e,t){var r=_slicedToArray(l.revivers[e]||[],1)[0];if(!r)throw new Error("Unregistered type: "+e);return i&&!("revive"in r)?t:r[i&&r.revive?"revive":!i&&r.reviveAsync?"reviveAsync":"revive"](t,u)}var p=[];function checkUndefined(e){return hasConstructorOf(e,f)?void 0:e}var y,v=function revivePlainObjects(){var r=[];if(Object.entries(n).forEach((function(e){var t=_slicedToArray(e,2),i=t[0],o=t[1];"#"!==o&&[].concat(o).forEach((function(e){_slicedToArray(l.revivers[e]||[null,{}],2)[1].plain&&(r.push({keypath:i,type:e}),delete n[i]);}));})),r.length)return r.sort(nestedPathsFirst).reduce((function reducer(r,n){var i=n.keypath,o=n.type;if(isThenable(r))return r.then((function(e){return reducer(e,{keypath:i,type:o})}));var a=getByKeyPath(t,i);if(hasConstructorOf(a=executeReviver(o,a),e))return a.then((function(e){var r=setAtKeyPath(t,i,e);r===e&&(t=r);}));var c=setAtKeyPath(t,i,a);c===a&&(t=c);}),void 0)}();return hasConstructorOf(v,e)?y=v.then((function(){return t})):(y=function _revive(t,r,i,u,l){if(!s||"$types"!==t){var y=n[t],v=a(r);if(v||isPlainObject(r)){var b=v?new Array(r.length):{};for(o(r).forEach((function(n){var o=_revive(t+(t?".":"")+escapeKeyPathComponent(n),r[n],i||b,b,n),a=function set(e){return hasConstructorOf(e,f)?b[n]=void 0:void 0!==e&&(b[n]=e),e};hasConstructorOf(o,e)?p.push(o.then((function(e){return a(e)}))):a(o);})),r=b;c.length;){var d=_slicedToArray(c[0],4),h=d[0],g=d[1],m=d[2],O=d[3],_=getByKeyPath(h,g);if(void 0===_)break;m[O]=_,c.splice(0,1);}}if(!y)return r;if("#"===y){var j=getByKeyPath(i,r.slice(1));return void 0===j&&c.push([i,r.slice(1),u,l]),j}return [].concat(y).reduce((function reducer(t,r){return hasConstructorOf(t,e)?t.then((function(e){return reducer(e,r)})):executeReviver(r,t)}),r)}}("",t,null),p.length&&(y=e.resolve(y).then((function(t){return e.all([t].concat(p))})).then((function(e){return _slicedToArray(e,1)[0]})))),isThenable(y)?i&&r.throwOnBadSyncType?function(){throw new TypeError("Sync method requested but async result obtained")}():hasConstructorOf(y,e)?y.p.then(checkUndefined):y:!i&&r.throwOnBadSyncType?function(){throw new TypeError("Async method requested but sync result obtained")}():i?checkUndefined(y):Promise.resolve(checkUndefined(y))}},{key:"reviveSync",value:function reviveSync(e,t){return this.revive(e,_objectSpread2(_objectSpread2({throwOnBadSyncType:!0},t),{},{sync:!0}))}},{key:"reviveAsync",value:function reviveAsync(e,t){return this.revive(e,_objectSpread2(_objectSpread2({throwOnBadSyncType:!0},t),{},{sync:!1}))}},{key:"register",value:function register(e,t){return t=t||{},[].concat(e).forEach((function R(e){var r=this;if(a(e))return e.map((function(e){return R.call(r,e)}));e&&o(e).forEach((function(r){if("#"===r)throw new TypeError("# cannot be used as a type name as it is reserved for cyclic objects");if(Typeson.JSON_TYPES.includes(r))throw new TypeError("Plain JSON object types are reserved as type names");var n=e[r],i=n&&n.testPlainObjects?this.plainObjectReplacers:this.nonplainObjectReplacers,o=i.filter((function(e){return e.type===r}));if(o.length&&(i.splice(i.indexOf(o[0]),1),delete this.revivers[r],delete this.types[r]),"function"==typeof n){var c=n;n={test:function test(e){return e&&e.constructor===c},replace:function replace(e){return _objectSpread2({},e)},revive:function revive(e){return Object.assign(Object.create(c.prototype),e)}};}else if(a(n)){var u=_slicedToArray(n,3);n={test:u[0],replace:u[1],revive:u[2]};}if(n&&n.test){var s={type:r,test:n.test.bind(n)};n.replace&&(s.replace=n.replace.bind(n)),n.replaceAsync&&(s.replaceAsync=n.replaceAsync.bind(n));var f="number"==typeof t.fallback?t.fallback:t.fallback?0:Number.POSITIVE_INFINITY;if(n.testPlainObjects?this.plainObjectReplacers.splice(f,0,s):this.nonplainObjectReplacers.splice(f,0,s),n.revive||n.reviveAsync){var l={};n.revive&&(l.revive=n.revive.bind(n)),n.reviveAsync&&(l.reviveAsync=n.reviveAsync.bind(n)),this.revivers[r]=[l,{plain:n.testPlainObjects}];}this.types[r]=n;}}),this);}),this),this}}]),Typeson}(),f=function Undefined(){_classCallCheck(this,Undefined);};f.__typeson__type__="TypesonUndefined",s.Undefined=f,s.Promise=e,s.isThenable=isThenable,s.toStringTag=toStringTag,s.hasConstructorOf=hasConstructorOf,s.isObject=isObject,s.isPlainObject=isPlainObject,s.isUserObject=function isUserObject(e){if(!e||"Object"!==toStringTag(e))return !1;var t=n(e);return !t||(hasConstructorOf(e,Object)||isUserObject(t))},s.escapeKeyPathComponent=escapeKeyPathComponent,s.unescapeKeyPathComponent=unescapeKeyPathComponent,s.getByKeyPath=getByKeyPath,s.getJSONType=function getJSONType(e){return null===e?"null":Array.isArray(e)?"array":_typeof(e)},s.JSON_TYPES=["null","boolean","number","string","array","object"];for(var l={userObject:{test:function test(e,t){return s.isUserObject(e)},replace:function replace(e){return function _objectSpread2$1(e){for(var t=1;t<arguments.length;t++){var r=null!=arguments[t]?arguments[t]:{};t%2?ownKeys$1(Object(r),!0).forEach((function(t){_defineProperty$1(e,t,r[t]);})):Object.getOwnPropertyDescriptors?Object.defineProperties(e,Object.getOwnPropertyDescriptors(r)):ownKeys$1(Object(r)).forEach((function(t){Object.defineProperty(e,t,Object.getOwnPropertyDescriptor(r,t));}));}return e}({},e)},revive:function revive(e){return e}}},p=[{arrayNonindexKeys:{testPlainObjects:!0,test:function test(e,t){return !!Array.isArray(e)&&(Object.keys(e).some((function(e){return String(Number.parseInt(e))!==e}))&&(t.iterateIn="object",t.addLength=!0),!0)},replace:function replace(e,t){return t.iterateUnsetNumeric=!0,e},revive:function revive(e){if(Array.isArray(e))return e;var t=[];return Object.keys(e).forEach((function(r){var n=e[r];t[r]=n;})),t}}},{sparseUndefined:{test:function test(e,t){return void 0===e&&!1===t.ownKeys},replace:function replace(e){return 0},revive:function revive(e){}}}],y={undef:{test:function test(e,t){return void 0===e&&(t.ownKeys||!("ownKeys"in t))},replace:function replace(e){return 0},revive:function revive(e){return new s.Undefined}}},v={StringObject:{test:function test(e){return "String"===s.toStringTag(e)&&"object"===_typeof$1(e)},replace:function replace(e){return String(e)},revive:function revive(e){return new String(e)}},BooleanObject:{test:function test(e){return "Boolean"===s.toStringTag(e)&&"object"===_typeof$1(e)},replace:function replace(e){return Boolean(e)},revive:function revive(e){return new Boolean(e)}},NumberObject:{test:function test(e){return "Number"===s.toStringTag(e)&&"object"===_typeof$1(e)},replace:function replace(e){return Number(e)},revive:function revive(e){return new Number(e)}}},b=[{nan:{test:function test(e){return Number.isNaN(e)},replace:function replace(e){return "NaN"},revive:function revive(e){return Number.NaN}}},{infinity:{test:function test(e){return e===Number.POSITIVE_INFINITY},replace:function replace(e){return "Infinity"},revive:function revive(e){return Number.POSITIVE_INFINITY}}},{negativeInfinity:{test:function test(e){return e===Number.NEGATIVE_INFINITY},replace:function replace(e){return "-Infinity"},revive:function revive(e){return Number.NEGATIVE_INFINITY}}}],d={date:{test:function test(e){return "Date"===s.toStringTag(e)},replace:function replace(e){var t=e.getTime();return Number.isNaN(t)?"NaN":t},revive:function revive(e){return "NaN"===e?new Date(Number.NaN):new Date(e)}}},h={regexp:{test:function test(e){return "RegExp"===s.toStringTag(e)},replace:function replace(e){return {source:e.source,flags:(e.global?"g":"")+(e.ignoreCase?"i":"")+(e.multiline?"m":"")+(e.sticky?"y":"")+(e.unicode?"u":"")}},revive:function revive(e){var t=e.source,r=e.flags;return new RegExp(t,r)}}},g={map:{test:function test(e){return "Map"===s.toStringTag(e)},replace:function replace(e){return _toConsumableArray$1(e.entries())},revive:function revive(e){return new Map(e)}}},m={set:{test:function test(e){return "Set"===s.toStringTag(e)},replace:function replace(e){return _toConsumableArray$1(e.values())},revive:function revive(e){return new Set(e)}}},O="ABCDEFGHIJKLMNOPQRSTUVWXYZabcdefghijklmnopqrstuvwxyz0123456789+/",_=new Uint8Array(256),j=0;j<O.length;j++)_[O.charCodeAt(j)]=j;var S=function encode(e,t,r){null==r&&(r=e.byteLength);for(var n=new Uint8Array(e,t||0,r),i=n.length,o="",a=0;a<i;a+=3)o+=O[n[a]>>2],o+=O[(3&n[a])<<4|n[a+1]>>4],o+=O[(15&n[a+1])<<2|n[a+2]>>6],o+=O[63&n[a+2]];return i%3==2?o=o.slice(0,-1)+"=":i%3==1&&(o=o.slice(0,-2)+"=="),o},T=function decode(e){var t,r,n,i,o=e.length,a=.75*e.length,c=0;"="===e[e.length-1]&&(a--,"="===e[e.length-2]&&a--);for(var u=new ArrayBuffer(a),s=new Uint8Array(u),f=0;f<o;f+=4)t=_[e.charCodeAt(f)],r=_[e.charCodeAt(f+1)],n=_[e.charCodeAt(f+2)],i=_[e.charCodeAt(f+3)],s[c++]=t<<2|r>>4,s[c++]=(15&r)<<4|n>>2,s[c++]=(3&n)<<6|63&i;return u},w={arraybuffer:{test:function test(e){return "ArrayBuffer"===s.toStringTag(e)},replace:function replace(e,t){t.buffers||(t.buffers=[]);var r=t.buffers.indexOf(e);return r>-1?{index:r}:(t.buffers.push(e),S(e))},revive:function revive(e,t){if(t.buffers||(t.buffers=[]),"object"===_typeof$1(e))return t.buffers[e.index];var r=T(e);return t.buffers.push(r),r}}},A="undefined"==typeof self?commonjsGlobal:self,P={};["Int8Array","Uint8Array","Uint8ClampedArray","Int16Array","Uint16Array","Int32Array","Uint32Array","Float32Array","Float64Array"].forEach((function(e){var t=e,r=A[t];r&&(P[e.toLowerCase()]={test:function test(e){return s.toStringTag(e)===t},replace:function replace(e,t){var r=e.buffer,n=e.byteOffset,i=e.length;t.buffers||(t.buffers=[]);var o=t.buffers.indexOf(r);return o>-1?{index:o,byteOffset:n,length:i}:(t.buffers.push(r),{encoded:S(r),byteOffset:n,length:i})},revive:function revive(e,t){t.buffers||(t.buffers=[]);var n,i=e.byteOffset,o=e.length,a=e.encoded,c=e.index;return "index"in e?n=t.buffers[c]:(n=T(a),t.buffers.push(n)),new r(n,i,o)}});}));var I={dataview:{test:function test(e){return "DataView"===s.toStringTag(e)},replace:function replace(e,t){var r=e.buffer,n=e.byteOffset,i=e.byteLength;t.buffers||(t.buffers=[]);var o=t.buffers.indexOf(r);return o>-1?{index:o,byteOffset:n,byteLength:i}:(t.buffers.push(r),{encoded:S(r),byteOffset:n,byteLength:i})},revive:function revive(e,t){t.buffers||(t.buffers=[]);var r,n=e.byteOffset,i=e.byteLength,o=e.encoded,a=e.index;return "index"in e?r=t.buffers[a]:(r=T(o),t.buffers.push(r)),new DataView(r,n,i)}}},C={IntlCollator:{test:function test(e){return s.hasConstructorOf(e,Intl.Collator)},replace:function replace(e){return e.resolvedOptions()},revive:function revive(e){return new Intl.Collator(e.locale,e)}},IntlDateTimeFormat:{test:function test(e){return s.hasConstructorOf(e,Intl.DateTimeFormat)},replace:function replace(e){return e.resolvedOptions()},revive:function revive(e){return new Intl.DateTimeFormat(e.locale,e)}},IntlNumberFormat:{test:function test(e){return s.hasConstructorOf(e,Intl.NumberFormat)},replace:function replace(e){return e.resolvedOptions()},revive:function revive(e){return new Intl.NumberFormat(e.locale,e)}}};function string2arraybuffer(e){for(var t=new Uint8Array(e.length),r=0;r<e.length;r++)t[r]=e.charCodeAt(r);return t.buffer}var N={file:{test:function test(e){return "File"===s.toStringTag(e)},replace:function replace(e){var t=new XMLHttpRequest;if(t.overrideMimeType("text/plain; charset=x-user-defined"),t.open("GET",URL.createObjectURL(e),!1),t.send(),200!==t.status&&0!==t.status)throw new Error("Bad File access: "+t.status);return {type:e.type,stringContents:t.responseText,name:e.name,lastModified:e.lastModified}},revive:function revive(e){var t=e.name,r=e.type,n=e.stringContents,i=e.lastModified;return new File([string2arraybuffer(n)],t,{type:r,lastModified:i})},replaceAsync:function replaceAsync(e){return new s.Promise((function(t,r){var n=new FileReader;n.addEventListener("load",(function(){t({type:e.type,stringContents:n.result,name:e.name,lastModified:e.lastModified});})),n.addEventListener("error",(function(){r(n.error);})),n.readAsBinaryString(e);}))}}},k={bigint:{test:function test(e){return "bigint"==typeof e},replace:function replace(e){return String(e)},revive:function revive(e){return BigInt(e)}}},E={bigintObject:{test:function test(e){return "object"===_typeof$1(e)&&s.hasConstructorOf(e,BigInt)},replace:function replace(e){return String(e)},revive:function revive(e){return new Object(BigInt(e))}}},B={cryptokey:{test:function test(e){return "CryptoKey"===s.toStringTag(e)&&e.extractable},replaceAsync:function replaceAsync(e){return new s.Promise((function(t,r){crypto.subtle.exportKey("jwk",e).catch((function(e){r(e);})).then((function(r){t({jwk:r,algorithm:e.algorithm,usages:e.usages});}));}))},revive:function revive(e){var t=e.jwk,r=e.algorithm,n=e.usages;return crypto.subtle.importKey("jwk",t,r,!0,n)}}};return [l,y,p,v,b,d,h,{imagedata:{test:function test(e){return "ImageData"===s.toStringTag(e)},replace:function replace(e){return {array:_toConsumableArray$1(e.data),width:e.width,height:e.height}},revive:function revive(e){return new ImageData(new Uint8ClampedArray(e.array),e.width,e.height)}}},{imagebitmap:{test:function test(e){return "ImageBitmap"===s.toStringTag(e)||e&&e.dataset&&"ImageBitmap"===e.dataset.toStringTag},replace:function replace(e){var t=document.createElement("canvas");return t.getContext("2d").drawImage(e,0,0),t.toDataURL()},revive:function revive(e){var t=document.createElement("canvas"),r=t.getContext("2d"),n=document.createElement("img");return n.addEventListener("load",(function(){r.drawImage(n,0,0);})),n.src=e,t},reviveAsync:function reviveAsync(e){var t=document.createElement("canvas"),r=t.getContext("2d"),n=document.createElement("img");return n.addEventListener("load",(function(){r.drawImage(n,0,0);})),n.src=e,createImageBitmap(t)}}},N,{file:N.file,filelist:{test:function test(e){return "FileList"===s.toStringTag(e)},replace:function replace(e){for(var t=[],r=0;r<e.length;r++)t[r]=e.item(r);return t},revive:function revive(e){return new(function(){function FileList(){_classCallCheck$1(this,FileList),this._files=arguments[0],this.length=this._files.length;}return function _createClass$1(e,t,r){return t&&_defineProperties$1(e.prototype,t),r&&_defineProperties$1(e,r),e}(FileList,[{key:"item",value:function item(e){return this._files[e]}},{key:Symbol.toStringTag,get:function get(){return "FileList"}}]),FileList}())(e)}}},{blob:{test:function test(e){return "Blob"===s.toStringTag(e)},replace:function replace(e){var t=new XMLHttpRequest;if(t.overrideMimeType("text/plain; charset=x-user-defined"),t.open("GET",URL.createObjectURL(e),!1),t.send(),200!==t.status&&0!==t.status)throw new Error("Bad Blob access: "+t.status);return {type:e.type,stringContents:t.responseText}},revive:function revive(e){var t=e.type,r=e.stringContents;return new Blob([string2arraybuffer(r)],{type:t})},replaceAsync:function replaceAsync(e){return new s.Promise((function(t,r){var n=new FileReader;n.addEventListener("load",(function(){t({type:e.type,stringContents:n.result});})),n.addEventListener("error",(function(){r(n.error);})),n.readAsBinaryString(e);}))}}}].concat("function"==typeof Map?g:[],"function"==typeof Set?m:[],"function"==typeof ArrayBuffer?w:[],"function"==typeof Uint8Array?P:[],"function"==typeof DataView?I:[],"undefined"!=typeof Intl?C:[],"undefined"!=typeof crypto?B:[],"undefined"!=typeof BigInt?[k,E]:[])}));
-
- });
-
- /*
- * base64-arraybuffer
- * https://github.com/niklasvh/base64-arraybuffer
- *
- * Copyright (c) 2017 Brett Zamir, 2012 Niklas von Hertzen
- * Licensed under the MIT license.
- */
- var chars = 'ABCDEFGHIJKLMNOPQRSTUVWXYZabcdefghijklmnopqrstuvwxyz0123456789+/'; // Use a lookup table to find the index.
-
- var lookup = new Uint8Array(256);
-
- for (var i = 0; i < chars.length; i++) {
- lookup[chars.codePointAt(i)] = i;
- }
- /**
- * @param {ArrayBuffer} arraybuffer
- * @param {Integer} byteOffset
- * @param {Integer} lngth
- * @returns {string}
- */
-
-
- var encode = function encode(arraybuffer, byteOffset, lngth) {
- if (lngth === null || lngth === undefined) {
- lngth = arraybuffer.byteLength; // Needed for Safari
- }
-
- var bytes = new Uint8Array(arraybuffer, byteOffset || 0, // Default needed for Safari
- lngth);
- var len = bytes.length;
- var base64 = '';
-
- for (var _i = 0; _i < len; _i += 3) {
- base64 += chars[bytes[_i] >> 2];
- base64 += chars[(bytes[_i] & 3) << 4 | bytes[_i + 1] >> 4];
- base64 += chars[(bytes[_i + 1] & 15) << 2 | bytes[_i + 2] >> 6];
- base64 += chars[bytes[_i + 2] & 63];
- }
-
- if (len % 3 === 2) {
- base64 = base64.slice(0, -1) + '=';
- } else if (len % 3 === 1) {
- base64 = base64.slice(0, -2) + '==';
- }
-
- return base64;
- };
- /**
- * @param {string} base64
- * @returns {ArrayBuffer}
- */
-
- var decode = function decode(base64) {
- var len = base64.length;
- var bufferLength = base64.length * 0.75;
- var p = 0;
- var encoded1, encoded2, encoded3, encoded4;
-
- if (base64[base64.length - 1] === '=') {
- bufferLength--;
-
- if (base64[base64.length - 2] === '=') {
- bufferLength--;
- }
- }
-
- var arraybuffer = new ArrayBuffer(bufferLength),
- bytes = new Uint8Array(arraybuffer);
-
- for (var _i2 = 0; _i2 < len; _i2 += 4) {
- encoded1 = lookup[base64.codePointAt(_i2)];
- encoded2 = lookup[base64.codePointAt(_i2 + 1)];
- encoded3 = lookup[base64.codePointAt(_i2 + 2)];
- encoded4 = lookup[base64.codePointAt(_i2 + 3)];
- bytes[p++] = encoded1 << 2 | encoded2 >> 4;
- bytes[p++] = (encoded2 & 15) << 4 | encoded3 >> 2;
- bytes[p++] = (encoded3 & 3) << 6 | encoded4 & 63;
- }
-
- return arraybuffer;
- };
-
- /* eslint-env browser, node */
- var _global = typeof self === 'undefined' ? global : self;
- var exportObj = {};
- [
- 'Int8Array',
- 'Uint8Array',
- 'Uint8ClampedArray',
- 'Int16Array',
- 'Uint16Array',
- 'Int32Array',
- 'Uint32Array',
- 'Float32Array',
- 'Float64Array'
- ].forEach(function (typeName) {
- var arrType = typeName;
- var TypedArray = _global[arrType];
- if (TypedArray) {
- exportObj[typeName.toLowerCase() + "2"] = {
- test: function (x) { return typeson.toStringTag(x) === arrType; },
- replace: function (_a) {
- var buffer = _a.buffer, byteOffset = _a.byteOffset, length = _a.length;
- return {
- buffer: buffer,
- byteOffset: byteOffset,
- length: length
- };
- },
- revive: function (b64Obj) {
- var buffer = b64Obj.buffer, byteOffset = b64Obj.byteOffset, length = b64Obj.length;
- return new TypedArray(buffer, byteOffset, length);
- }
- };
- }
- });
-
- var arrayBuffer = {
- arraybuffer: {
- test: function (x) { return typeson.toStringTag(x) === 'ArrayBuffer'; },
- replace: function (b) {
- return encode(b, 0, b.byteLength);
- },
- revive: function (b64) {
- var buffer = decode(b64);
- return buffer;
- }
- }
- };
- // See also typed-arrays!
-
- var TSON = new typeson().register(structuredCloning);
- var readBlobsSynchronously = 'FileReaderSync' in self; // true in workers only.
- var blobsToAwait = [];
- var blobsToAwaitPos = 0;
- // Need to patch encapsulateAsync as it does not work as of typeson 5.8.2
- // Also, current version of typespn-registry-1.0.0-alpha.21 does not
- // encapsulate/revive Blobs correctly (fails one of the unit tests in
- // this library (test 'export-format'))
- TSON.register([
- arrayBuffer,
- exportObj, {
- blob2: {
- test: function (x) { return typeson.toStringTag(x) === 'Blob'; },
- replace: function (b) {
- if (b.isClosed) { // On MDN, but not in https://w3c.github.io/FileAPI/#dfn-Blob
- throw new Error('The Blob is closed');
- }
- if (readBlobsSynchronously) {
- var data = readBlobSync(b, 'binary');
- var base64 = encode(data, 0, data.byteLength);
- return {
- type: b.type,
- data: base64
- };
- }
- else {
- blobsToAwait.push(b); // This will also make TSON.mustFinalize() return true.
- var result = {
- type: b.type,
- data: { start: blobsToAwaitPos, end: blobsToAwaitPos + b.size }
- };
- blobsToAwaitPos += b.size;
- return result;
- }
- },
- finalize: function (b, ba) {
- b.data = encode(ba, 0, ba.byteLength);
- },
- revive: function (_a) {
- var type = _a.type, data = _a.data;
- return new Blob([decode(data)], { type: type });
- }
- }
- }
- ]);
- TSON.mustFinalize = function () { return blobsToAwait.length > 0; };
- TSON.finalize = function (items) { return __awaiter(void 0, void 0, void 0, function () {
- var allChunks, _i, items_1, item, types, arrayType, keyPath, typeName, typeSpec, b;
- return __generator(this, function (_a) {
- switch (_a.label) {
- case 0: return [4 /*yield*/, readBlobAsync(new Blob(blobsToAwait), 'binary')];
- case 1:
- allChunks = _a.sent();
- if (items) {
- for (_i = 0, items_1 = items; _i < items_1.length; _i++) {
- item = items_1[_i];
- // Manually go through all "blob" types in the result
- // and lookup the data slice they point at.
- if (item.$types) {
- types = item.$types;
- arrayType = types.$;
- if (arrayType)
- types = types.$;
- for (keyPath in types) {
- typeName = types[keyPath];
- typeSpec = TSON.types[typeName];
- if (typeSpec && typeSpec.finalize) {
- b = Dexie__default["default"].getByKeyPath(item, arrayType ? "$." + keyPath : keyPath);
- typeSpec.finalize(b, allChunks.slice(b.start, b.end));
- }
- }
- }
- }
- }
- // Free up memory
- blobsToAwait = [];
- return [2 /*return*/];
- }
- });
- }); };
-
- var DEFAULT_ROWS_PER_CHUNK = 2000;
- function exportDB(db, options) {
- return __awaiter(this, void 0, void 0, function () {
- function exportAll() {
- return __awaiter(this, void 0, void 0, function () {
- var tablesRowCounts, emptyExportJson, posEndDataArray, firstJsonSlice, filter, _loop_1, _i, tables_1, tableName;
- return __generator(this, function (_a) {
- switch (_a.label) {
- case 0: return [4 /*yield*/, Promise.all(db.tables.map(function (table) { return table.count(); }))];
- case 1:
- tablesRowCounts = _a.sent();
- tablesRowCounts.forEach(function (rowCount, i) { return tables[i].rowCount = rowCount; });
- progress.totalRows = tablesRowCounts.reduce(function (p, c) { return p + c; });
- emptyExportJson = JSON.stringify(emptyExport, undefined, prettyJson ? 2 : undefined);
- posEndDataArray = emptyExportJson.lastIndexOf(']');
- firstJsonSlice = emptyExportJson.substring(0, posEndDataArray);
- slices.push(firstJsonSlice);
- filter = options.filter;
- _loop_1 = function (tableName) {
- var table, primKey, inbound, LIMIT, emptyTableExport, emptyTableExportJson, posEndRowsArray, lastKey, lastNumRows, mayHaveMoreRows, _loop_2, state_1;
- return __generator(this, function (_b) {
- switch (_b.label) {
- case 0:
- table = db.table(tableName);
- primKey = table.schema.primKey;
- inbound = !!primKey.keyPath;
- LIMIT = options.numRowsPerChunk || DEFAULT_ROWS_PER_CHUNK;
- emptyTableExport = inbound ? {
- tableName: table.name,
- inbound: true,
- rows: []
- } : {
- tableName: table.name,
- inbound: false,
- rows: []
- };
- emptyTableExportJson = JSON.stringify(emptyTableExport, undefined, prettyJson ? 2 : undefined);
- if (prettyJson) {
- // Increase indentation according to this:
- // {
- // ...
- // data: [
- // ...
- // data: [
- // 123456<---- here
- // ]
- // ]
- // }
- emptyTableExportJson = emptyTableExportJson.split('\n').join('\n ');
- }
- posEndRowsArray = emptyTableExportJson.lastIndexOf(']');
- slices.push(emptyTableExportJson.substring(0, posEndRowsArray));
- lastKey = null;
- lastNumRows = 0;
- mayHaveMoreRows = true;
- _loop_2 = function () {
- var chunkedCollection, values, filteredValues, tsonValues, json, keys, keyvals, tsonTuples, json;
- return __generator(this, function (_c) {
- switch (_c.label) {
- case 0:
- if (progressCallback) {
- // Keep ongoing transaction private
- Dexie__default["default"].ignoreTransaction(function () { return progressCallback(progress); });
- }
- chunkedCollection = lastKey == null ?
- table.limit(LIMIT) :
- table.where(':id').above(lastKey).limit(LIMIT);
- return [4 /*yield*/, chunkedCollection.toArray()];
- case 1:
- values = _c.sent();
- if (values.length === 0)
- return [2 /*return*/, "break"];
- if (lastKey != null && lastNumRows > 0) {
- // Not initial chunk. Must add a comma:
- slices.push(",");
- if (prettyJson) {
- slices.push("\n ");
- }
- }
- mayHaveMoreRows = values.length === LIMIT;
- if (!inbound) return [3 /*break*/, 4];
- filteredValues = filter ?
- values.filter(function (value) { return filter(tableName, value); }) :
- values;
- tsonValues = filteredValues.map(function (value) { return TSON.encapsulate(value); });
- if (!TSON.mustFinalize()) return [3 /*break*/, 3];
- return [4 /*yield*/, Dexie__default["default"].waitFor(TSON.finalize(tsonValues))];
- case 2:
- _c.sent();
- _c.label = 3;
- case 3:
- json = JSON.stringify(tsonValues, undefined, prettyJson ? 2 : undefined);
- if (prettyJson)
- json = json.split('\n').join('\n ');
- // By generating a blob here, we give web platform the opportunity to store the contents
- // on disk and release RAM.
- slices.push(new Blob([json.substring(1, json.length - 1)]));
- lastNumRows = filteredValues.length;
- lastKey = values.length > 0 ?
- Dexie__default["default"].getByKeyPath(values[values.length - 1], primKey.keyPath) :
- null;
- return [3 /*break*/, 8];
- case 4: return [4 /*yield*/, chunkedCollection.primaryKeys()];
- case 5:
- keys = _c.sent();
- keyvals = keys.map(function (key, i) { return [key, values[i]]; });
- if (filter)
- keyvals = keyvals.filter(function (_a) {
- var key = _a[0], value = _a[1];
- return filter(tableName, value, key);
- });
- tsonTuples = keyvals.map(function (tuple) { return TSON.encapsulate(tuple); });
- if (!TSON.mustFinalize()) return [3 /*break*/, 7];
- return [4 /*yield*/, Dexie__default["default"].waitFor(TSON.finalize(tsonTuples))];
- case 6:
- _c.sent();
- _c.label = 7;
- case 7:
- json = JSON.stringify(tsonTuples, undefined, prettyJson ? 2 : undefined);
- if (prettyJson)
- json = json.split('\n').join('\n ');
- // By generating a blob here, we give web platform the opportunity to store the contents
- // on disk and release RAM.
- slices.push(new Blob([json.substring(1, json.length - 1)]));
- lastNumRows = keyvals.length;
- lastKey = keys.length > 0 ?
- keys[keys.length - 1] :
- null;
- _c.label = 8;
- case 8:
- progress.completedRows += values.length;
- return [2 /*return*/];
- }
- });
- };
- _b.label = 1;
- case 1:
- if (!mayHaveMoreRows) return [3 /*break*/, 3];
- return [5 /*yield**/, _loop_2()];
- case 2:
- state_1 = _b.sent();
- if (state_1 === "break")
- return [3 /*break*/, 3];
- return [3 /*break*/, 1];
- case 3:
- slices.push(emptyTableExportJson.substr(posEndRowsArray)); // "]}"
- progress.completedTables += 1;
- if (progress.completedTables < progress.totalTables) {
- slices.push(",");
- }
- return [2 /*return*/];
- }
- });
- };
- _i = 0, tables_1 = tables;
- _a.label = 2;
- case 2:
- if (!(_i < tables_1.length)) return [3 /*break*/, 5];
- tableName = tables_1[_i].name;
- return [5 /*yield**/, _loop_1(tableName)];
- case 3:
- _a.sent();
- _a.label = 4;
- case 4:
- _i++;
- return [3 /*break*/, 2];
- case 5:
- slices.push(emptyExportJson.substr(posEndDataArray));
- progress.done = true;
- if (progressCallback) {
- // Keep ongoing transaction private
- Dexie__default["default"].ignoreTransaction(function () { return progressCallback(progress); });
- }
- return [2 /*return*/];
- }
- });
- });
- }
- var slices, tables, prettyJson, emptyExport, progressCallback, progress;
- return __generator(this, function (_a) {
- switch (_a.label) {
- case 0:
- options = options || {};
- slices = [];
- tables = db.tables.map(function (table) { return ({
- name: table.name,
- schema: getSchemaString(table),
- rowCount: 0
- }); });
- prettyJson = options.prettyJson;
- emptyExport = {
- formatName: "dexie",
- formatVersion: 1,
- data: {
- databaseName: db.name,
- databaseVersion: db.verno,
- tables: tables,
- data: []
- }
- };
- progressCallback = options.progressCallback;
- progress = {
- done: false,
- completedRows: 0,
- completedTables: 0,
- totalRows: NaN,
- totalTables: db.tables.length
- };
- _a.label = 1;
- case 1:
- _a.trys.push([1, , 6, 7]);
- if (!options.noTransaction) return [3 /*break*/, 3];
- return [4 /*yield*/, exportAll()];
- case 2:
- _a.sent();
- return [3 /*break*/, 5];
- case 3: return [4 /*yield*/, db.transaction('r', db.tables, exportAll)];
- case 4:
- _a.sent();
- _a.label = 5;
- case 5: return [3 /*break*/, 7];
- case 6:
- TSON.finalize(); // Free up mem if error has occurred
- return [7 /*endfinally*/];
- case 7: return [2 /*return*/, new Blob(slices, { type: "text/json" })];
- }
- });
- });
- }
-
- var VERSION = 1;
-
- var fakeStream = {Stream: function(){}};
-
- var clarinet_1 = createCommonjsModule(function (module, exports) {
- (function (clarinet) {
-
- // non node-js needs to set clarinet debug on root
- var env =(typeof process === 'object' && process.env)
- ? process.env
- : self;
-
- clarinet.parser = function (opt) { return new CParser(opt);};
- clarinet.CParser = CParser;
- clarinet.CStream = CStream;
- clarinet.createStream = createStream;
- clarinet.MAX_BUFFER_LENGTH = 10 * 1024 * 1024;
- clarinet.DEBUG = (env.CDEBUG==='debug');
- clarinet.INFO = (env.CDEBUG==='debug' || env.CDEBUG==='info');
- clarinet.EVENTS =
- [ "value"
- , "string"
- , "key"
- , "openobject"
- , "closeobject"
- , "openarray"
- , "closearray"
- , "error"
- , "end"
- , "ready"
- ];
-
- var buffers = {
- textNode: undefined,
- numberNode: ""
- }
- , streamWraps = clarinet.EVENTS.filter(function (ev) {
- return ev !== "error" && ev !== "end";
- })
- , S = 0
- , Stream
- ;
-
- clarinet.STATE =
- { BEGIN : S++
- , VALUE : S++ // general stuff
- , OPEN_OBJECT : S++ // {
- , CLOSE_OBJECT : S++ // }
- , OPEN_ARRAY : S++ // [
- , CLOSE_ARRAY : S++ // ]
- , TEXT_ESCAPE : S++ // \ stuff
- , STRING : S++ // ""
- , BACKSLASH : S++
- , END : S++ // No more stack
- , OPEN_KEY : S++ // , "a"
- , CLOSE_KEY : S++ // :
- , TRUE : S++ // r
- , TRUE2 : S++ // u
- , TRUE3 : S++ // e
- , FALSE : S++ // a
- , FALSE2 : S++ // l
- , FALSE3 : S++ // s
- , FALSE4 : S++ // e
- , NULL : S++ // u
- , NULL2 : S++ // l
- , NULL3 : S++ // l
- , NUMBER_DECIMAL_POINT : S++ // .
- , NUMBER_DIGIT : S++ // [0-9]
- };
-
- for (var s_ in clarinet.STATE) clarinet.STATE[clarinet.STATE[s_]] = s_;
-
- // switcharoo
- S = clarinet.STATE;
-
- const Char = {
- tab : 0x09, // \t
- lineFeed : 0x0A, // \n
- carriageReturn : 0x0D, // \r
- space : 0x20, // " "
-
- doubleQuote : 0x22, // "
- plus : 0x2B, // +
- comma : 0x2C, // ,
- minus : 0x2D, // -
- period : 0x2E, // .
-
- _0 : 0x30, // 0
- _9 : 0x39, // 9
-
- colon : 0x3A, // :
-
- E : 0x45, // E
-
- openBracket : 0x5B, // [
- backslash : 0x5C, // \
- closeBracket : 0x5D, // ]
-
- a : 0x61, // a
- b : 0x62, // b
- e : 0x65, // e
- f : 0x66, // f
- l : 0x6C, // l
- n : 0x6E, // n
- r : 0x72, // r
- s : 0x73, // s
- t : 0x74, // t
- u : 0x75, // u
-
- openBrace : 0x7B, // {
- closeBrace : 0x7D, // }
- };
-
- if (!Object.create) {
- Object.create = function (o) {
- function f () { this["__proto__"] = o; }
- f.prototype = o;
- return new f;
- };
- }
-
- if (!Object.getPrototypeOf) {
- Object.getPrototypeOf = function (o) {
- return o["__proto__"];
- };
- }
-
- if (!Object.keys) {
- Object.keys = function (o) {
- var a = [];
- for (var i in o) if (o.hasOwnProperty(i)) a.push(i);
- return a;
- };
- }
-
- function checkBufferLength (parser) {
- var maxAllowed = Math.max(clarinet.MAX_BUFFER_LENGTH, 10)
- , maxActual = 0
- ;
- for (var buffer in buffers) {
- var len = parser[buffer] === undefined ? 0 : parser[buffer].length;
- if (len > maxAllowed) {
- switch (buffer) {
- case "text":
- closeText(parser);
- break;
-
- default:
- error(parser, "Max buffer length exceeded: "+ buffer);
- }
- }
- maxActual = Math.max(maxActual, len);
- }
- parser.bufferCheckPosition = (clarinet.MAX_BUFFER_LENGTH - maxActual)
- + parser.position;
- }
-
- function clearBuffers (parser) {
- for (var buffer in buffers) {
- parser[buffer] = buffers[buffer];
- }
- }
-
- var stringTokenPattern = /[\\"\n]/g;
-
- function CParser (opt) {
- if (!(this instanceof CParser)) return new CParser (opt);
-
- var parser = this;
- clearBuffers(parser);
- parser.bufferCheckPosition = clarinet.MAX_BUFFER_LENGTH;
- parser.q = parser.c = parser.p = "";
- parser.opt = opt || {};
- parser.closed = parser.closedRoot = parser.sawRoot = false;
- parser.tag = parser.error = null;
- parser.state = S.BEGIN;
- parser.stack = new Array();
- // mostly just for error reporting
- parser.position = parser.column = 0;
- parser.line = 1;
- parser.slashed = false;
- parser.unicodeI = 0;
- parser.unicodeS = null;
- parser.depth = 0;
- emit(parser, "onready");
- }
-
- CParser.prototype =
- { end : function () { end(this); }
- , write : write
- , resume : function () { this.error = null; return this; }
- , close : function () { return this.write(null); }
- };
-
- try { Stream = fakeStream.Stream; }
- catch (ex) { Stream = function () {}; }
-
- function createStream (opt) { return new CStream(opt); }
-
- function CStream (opt) {
- if (!(this instanceof CStream)) return new CStream(opt);
-
- this._parser = new CParser(opt);
- this.writable = true;
- this.readable = true;
-
- //var Buffer = this.Buffer || function Buffer () {}; // if we don't have Buffers, fake it so we can do `var instanceof Buffer` and not throw an error
- this.bytes_remaining = 0; // number of bytes remaining in multi byte utf8 char to read after split boundary
- this.bytes_in_sequence = 0; // bytes in multi byte utf8 char to read
- this.temp_buffs = { "2": new Buffer(2), "3": new Buffer(3), "4": new Buffer(4) }; // for rebuilding chars split before boundary is reached
- this.string = '';
-
- var me = this;
- Stream.apply(me);
-
- this._parser.onend = function () { me.emit("end"); };
- this._parser.onerror = function (er) {
- me.emit("error", er);
- me._parser.error = null;
- };
-
- streamWraps.forEach(function (ev) {
- Object.defineProperty(me, "on" + ev,
- { get : function () { return me._parser["on" + ev]; }
- , set : function (h) {
- if (!h) {
- me.removeAllListeners(ev);
- me._parser["on"+ev] = h;
- return h;
- }
- me.on(ev, h);
- }
- , enumerable : true
- , configurable : false
- });
- });
- }
-
- CStream.prototype = Object.create(Stream.prototype,
- { constructor: { value: CStream } });
-
- CStream.prototype.write = function (data) {
- data = new Buffer(data);
- for (var i = 0; i < data.length; i++) {
- var n = data[i];
-
- // check for carry over of a multi byte char split between data chunks
- // & fill temp buffer it with start of this data chunk up to the boundary limit set in the last iteration
- if (this.bytes_remaining > 0) {
- for (var j = 0; j < this.bytes_remaining; j++) {
- this.temp_buffs[this.bytes_in_sequence][this.bytes_in_sequence - this.bytes_remaining + j] = data[j];
- }
- this.string = this.temp_buffs[this.bytes_in_sequence].toString();
- this.bytes_in_sequence = this.bytes_remaining = 0;
-
- // move iterator forward by number of byte read during sequencing
- i = i + j - 1;
-
- // pass data to parser and move forward to parse rest of data
- this._parser.write(this.string);
- this.emit("data", this.string);
- continue;
- }
-
- // if no remainder bytes carried over, parse multi byte (>=128) chars one at a time
- if (this.bytes_remaining === 0 && n >= 128) {
- if ((n >= 194) && (n <= 223)) this.bytes_in_sequence = 2;
- if ((n >= 224) && (n <= 239)) this.bytes_in_sequence = 3;
- if ((n >= 240) && (n <= 244)) this.bytes_in_sequence = 4;
- if ((this.bytes_in_sequence + i) > data.length) { // if bytes needed to complete char fall outside data length, we have a boundary split
-
- for (var k = 0; k <= (data.length - 1 - i); k++) {
- this.temp_buffs[this.bytes_in_sequence][k] = data[i + k]; // fill temp data of correct size with bytes available in this chunk
- }
- this.bytes_remaining = (i + this.bytes_in_sequence) - data.length;
-
- // immediately return as we need another chunk to sequence the character
- return true;
- } else {
- this.string = data.slice(i, (i + this.bytes_in_sequence)).toString();
- i = i + this.bytes_in_sequence - 1;
-
- this._parser.write(this.string);
- this.emit("data", this.string);
- continue;
- }
- }
-
- // is there a range of characters that are immediately parsable?
- for (var p = i; p < data.length; p++) {
- if (data[p] >= 128) break;
- }
- this.string = data.slice(i, p).toString();
- this._parser.write(this.string);
- this.emit("data", this.string);
- i = p - 1;
-
- // handle any remaining characters using multibyte logic
- continue;
- }
- };
-
- CStream.prototype.end = function (chunk) {
- if (chunk && chunk.length) this._parser.write(chunk.toString());
- this._parser.end();
- return true;
- };
-
- CStream.prototype.on = function (ev, handler) {
- var me = this;
- if (!me._parser["on"+ev] && streamWraps.indexOf(ev) !== -1) {
- me._parser["on"+ev] = function () {
- var args = arguments.length === 1 ? [arguments[0]]
- : Array.apply(null, arguments);
- args.splice(0, 0, ev);
- me.emit.apply(me, args);
- };
- }
- return Stream.prototype.on.call(me, ev, handler);
- };
-
- CStream.prototype.destroy = function () {
- clearBuffers(this._parser);
- this.emit("close");
- };
-
- function emit(parser, event, data) {
- if(clarinet.INFO) console.log('-- emit', event, data);
- if (parser[event]) parser[event](data);
- }
-
- function emitNode(parser, event, data) {
- closeValue(parser);
- emit(parser, event, data);
- }
-
- function closeValue(parser, event) {
- parser.textNode = textopts(parser.opt, parser.textNode);
- if (parser.textNode !== undefined) {
- emit(parser, (event ? event : "onvalue"), parser.textNode);
- }
- parser.textNode = undefined;
- }
-
- function closeNumber(parser) {
- if (parser.numberNode)
- emit(parser, "onvalue", parseFloat(parser.numberNode));
- parser.numberNode = "";
- }
-
- function textopts (opt, text) {
- if (text === undefined) {
- return text;
- }
- if (opt.trim) text = text.trim();
- if (opt.normalize) text = text.replace(/\s+/g, " ");
- return text;
- }
-
- function error (parser, er) {
- closeValue(parser);
- er += "\nLine: "+parser.line+
- "\nColumn: "+parser.column+
- "\nChar: "+parser.c;
- er = new Error(er);
- parser.error = er;
- emit(parser, "onerror", er);
- return parser;
- }
-
- function end(parser) {
- if (parser.state !== S.VALUE || parser.depth !== 0)
- error(parser, "Unexpected end");
-
- closeValue(parser);
- parser.c = "";
- parser.closed = true;
- emit(parser, "onend");
- CParser.call(parser, parser.opt);
- return parser;
- }
-
- function isWhitespace(c) {
- return c === Char.carriageReturn || c === Char.lineFeed || c === Char.space || c === Char.tab;
- }
-
- function write (chunk) {
- var parser = this;
- if (this.error) throw this.error;
- if (parser.closed) return error(parser,
- "Cannot write after close. Assign an onready handler.");
- if (chunk === null) return end(parser);
- var i = 0, c = chunk.charCodeAt(0), p = parser.p;
- if (clarinet.DEBUG) console.log('write -> [' + chunk + ']');
- while (c) {
- p = c;
- parser.c = c = chunk.charCodeAt(i++);
- // if chunk doesnt have next, like streaming char by char
- // this way we need to check if previous is really previous
- // if not we need to reset to what the parser says is the previous
- // from buffer
- if(p !== c ) parser.p = p;
- else p = parser.p;
-
- if(!c) break;
-
- if (clarinet.DEBUG) console.log(i,c,clarinet.STATE[parser.state]);
- parser.position ++;
- if (c === Char.lineFeed) {
- parser.line ++;
- parser.column = 0;
- } else parser.column ++;
- switch (parser.state) {
-
- case S.BEGIN:
- if (c === Char.openBrace) parser.state = S.OPEN_OBJECT;
- else if (c === Char.openBracket) parser.state = S.OPEN_ARRAY;
- else if (!isWhitespace(c))
- error(parser, "Non-whitespace before {[.");
- continue;
-
- case S.OPEN_KEY:
- case S.OPEN_OBJECT:
- if (isWhitespace(c)) continue;
- if(parser.state === S.OPEN_KEY) parser.stack.push(S.CLOSE_KEY);
- else {
- if(c === Char.closeBrace) {
- emit(parser, 'onopenobject');
- this.depth++;
- emit(parser, 'oncloseobject');
- this.depth--;
- parser.state = parser.stack.pop() || S.VALUE;
- continue;
- } else parser.stack.push(S.CLOSE_OBJECT);
- }
- if(c === Char.doubleQuote) parser.state = S.STRING;
- else error(parser, "Malformed object key should start with \"");
- continue;
-
- case S.CLOSE_KEY:
- case S.CLOSE_OBJECT:
- if (isWhitespace(c)) continue;
- (parser.state === S.CLOSE_KEY) ? 'key' : 'object';
- if(c === Char.colon) {
- if(parser.state === S.CLOSE_OBJECT) {
- parser.stack.push(S.CLOSE_OBJECT);
- closeValue(parser, 'onopenobject');
- this.depth++;
- } else closeValue(parser, 'onkey');
- parser.state = S.VALUE;
- } else if (c === Char.closeBrace) {
- emitNode(parser, 'oncloseobject');
- this.depth--;
- parser.state = parser.stack.pop() || S.VALUE;
- } else if(c === Char.comma) {
- if(parser.state === S.CLOSE_OBJECT)
- parser.stack.push(S.CLOSE_OBJECT);
- closeValue(parser);
- parser.state = S.OPEN_KEY;
- } else error(parser, 'Bad object');
- continue;
-
- case S.OPEN_ARRAY: // after an array there always a value
- case S.VALUE:
- if (isWhitespace(c)) continue;
- if(parser.state===S.OPEN_ARRAY) {
- emit(parser, 'onopenarray');
- this.depth++;
- parser.state = S.VALUE;
- if(c === Char.closeBracket) {
- emit(parser, 'onclosearray');
- this.depth--;
- parser.state = parser.stack.pop() || S.VALUE;
- continue;
- } else {
- parser.stack.push(S.CLOSE_ARRAY);
- }
- }
- if(c === Char.doubleQuote) parser.state = S.STRING;
- else if(c === Char.openBrace) parser.state = S.OPEN_OBJECT;
- else if(c === Char.openBracket) parser.state = S.OPEN_ARRAY;
- else if(c === Char.t) parser.state = S.TRUE;
- else if(c === Char.f) parser.state = S.FALSE;
- else if(c === Char.n) parser.state = S.NULL;
- else if(c === Char.minus) { // keep and continue
- parser.numberNode += "-";
- } else if(Char._0 <= c && c <= Char._9) {
- parser.numberNode += String.fromCharCode(c);
- parser.state = S.NUMBER_DIGIT;
- } else error(parser, "Bad value");
- continue;
-
- case S.CLOSE_ARRAY:
- if(c === Char.comma) {
- parser.stack.push(S.CLOSE_ARRAY);
- closeValue(parser, 'onvalue');
- parser.state = S.VALUE;
- } else if (c === Char.closeBracket) {
- emitNode(parser, 'onclosearray');
- this.depth--;
- parser.state = parser.stack.pop() || S.VALUE;
- } else if (isWhitespace(c))
- continue;
- else error(parser, 'Bad array');
- continue;
-
- case S.STRING:
- if (parser.textNode === undefined) {
- parser.textNode = "";
- }
-
- // thanks thejh, this is an about 50% performance improvement.
- var starti = i-1
- , slashed = parser.slashed
- , unicodeI = parser.unicodeI
- ;
- STRING_BIGLOOP: while (true) {
- if (clarinet.DEBUG)
- console.log(i,c,clarinet.STATE[parser.state]
- ,slashed);
- // zero means "no unicode active". 1-4 mean "parse some more". end after 4.
- while (unicodeI > 0) {
- parser.unicodeS += String.fromCharCode(c);
- c = chunk.charCodeAt(i++);
- parser.position++;
- if (unicodeI === 4) {
- // TODO this might be slow? well, probably not used too often anyway
- parser.textNode += String.fromCharCode(parseInt(parser.unicodeS, 16));
- unicodeI = 0;
- starti = i-1;
- } else {
- unicodeI++;
- }
- // we can just break here: no stuff we skipped that still has to be sliced out or so
- if (!c) break STRING_BIGLOOP;
- }
- if (c === Char.doubleQuote && !slashed) {
- parser.state = parser.stack.pop() || S.VALUE;
- parser.textNode += chunk.substring(starti, i-1);
- parser.position += i - 1 - starti;
- break;
- }
- if (c === Char.backslash && !slashed) {
- slashed = true;
- parser.textNode += chunk.substring(starti, i-1);
- parser.position += i - 1 - starti;
- c = chunk.charCodeAt(i++);
- parser.position++;
- if (!c) break;
- }
- if (slashed) {
- slashed = false;
- if (c === Char.n) { parser.textNode += '\n'; }
- else if (c === Char.r) { parser.textNode += '\r'; }
- else if (c === Char.t) { parser.textNode += '\t'; }
- else if (c === Char.f) { parser.textNode += '\f'; }
- else if (c === Char.b) { parser.textNode += '\b'; }
- else if (c === Char.u) {
- // \uxxxx. meh!
- unicodeI = 1;
- parser.unicodeS = '';
- } else {
- parser.textNode += String.fromCharCode(c);
- }
- c = chunk.charCodeAt(i++);
- parser.position++;
- starti = i-1;
- if (!c) break;
- else continue;
- }
-
- stringTokenPattern.lastIndex = i;
- var reResult = stringTokenPattern.exec(chunk);
- if (reResult === null) {
- i = chunk.length+1;
- parser.textNode += chunk.substring(starti, i-1);
- parser.position += i - 1 - starti;
- break;
- }
- i = reResult.index+1;
- c = chunk.charCodeAt(reResult.index);
- if (!c) {
- parser.textNode += chunk.substring(starti, i-1);
- parser.position += i - 1 - starti;
- break;
- }
- }
- parser.slashed = slashed;
- parser.unicodeI = unicodeI;
- continue;
-
- case S.TRUE:
- if (c === Char.r) parser.state = S.TRUE2;
- else error(parser, 'Invalid true started with t'+ c);
- continue;
-
- case S.TRUE2:
- if (c === Char.u) parser.state = S.TRUE3;
- else error(parser, 'Invalid true started with tr'+ c);
- continue;
-
- case S.TRUE3:
- if(c === Char.e) {
- emit(parser, "onvalue", true);
- parser.state = parser.stack.pop() || S.VALUE;
- } else error(parser, 'Invalid true started with tru'+ c);
- continue;
-
- case S.FALSE:
- if (c === Char.a) parser.state = S.FALSE2;
- else error(parser, 'Invalid false started with f'+ c);
- continue;
-
- case S.FALSE2:
- if (c === Char.l) parser.state = S.FALSE3;
- else error(parser, 'Invalid false started with fa'+ c);
- continue;
-
- case S.FALSE3:
- if (c === Char.s) parser.state = S.FALSE4;
- else error(parser, 'Invalid false started with fal'+ c);
- continue;
-
- case S.FALSE4:
- if (c === Char.e) {
- emit(parser, "onvalue", false);
- parser.state = parser.stack.pop() || S.VALUE;
- } else error(parser, 'Invalid false started with fals'+ c);
- continue;
-
- case S.NULL:
- if (c === Char.u) parser.state = S.NULL2;
- else error(parser, 'Invalid null started with n'+ c);
- continue;
-
- case S.NULL2:
- if (c === Char.l) parser.state = S.NULL3;
- else error(parser, 'Invalid null started with nu'+ c);
- continue;
-
- case S.NULL3:
- if(c === Char.l) {
- emit(parser, "onvalue", null);
- parser.state = parser.stack.pop() || S.VALUE;
- } else error(parser, 'Invalid null started with nul'+ c);
- continue;
-
- case S.NUMBER_DECIMAL_POINT:
- if(c === Char.period) {
- parser.numberNode += ".";
- parser.state = S.NUMBER_DIGIT;
- } else error(parser, 'Leading zero not followed by .');
- continue;
-
- case S.NUMBER_DIGIT:
- if(Char._0 <= c && c <= Char._9) parser.numberNode += String.fromCharCode(c);
- else if (c === Char.period) {
- if(parser.numberNode.indexOf('.')!==-1)
- error(parser, 'Invalid number has two dots');
- parser.numberNode += ".";
- } else if (c === Char.e || c === Char.E) {
- if(parser.numberNode.indexOf('e')!==-1 ||
- parser.numberNode.indexOf('E')!==-1 )
- error(parser, 'Invalid number has two exponential');
- parser.numberNode += "e";
- } else if (c === Char.plus || c === Char.minus) {
- if(!(p === Char.e || p === Char.E))
- error(parser, 'Invalid symbol in number');
- parser.numberNode += String.fromCharCode(c);
- } else {
- closeNumber(parser);
- i--; // go back one
- parser.state = parser.stack.pop() || S.VALUE;
- }
- continue;
-
- default:
- error(parser, "Unknown state: " + parser.state);
- }
- }
- if (parser.position >= parser.bufferCheckPosition)
- checkBufferLength(parser);
- return parser;
- }
-
- })(exports);
- });
-
- function JsonStream(blob) {
- var pos = 0;
- var parser = JsonParser(true);
- var rv = {
- pullAsync: function (numBytes) {
- return __awaiter(this, void 0, void 0, function () {
- var slize, jsonPart, result;
- return __generator(this, function (_a) {
- switch (_a.label) {
- case 0:
- slize = blob.slice(pos, pos + numBytes);
- pos += numBytes;
- return [4 /*yield*/, readBlobAsync(slize, 'text')];
- case 1:
- jsonPart = _a.sent();
- result = parser.write(jsonPart);
- rv.result = result || {};
- return [2 /*return*/, result];
- }
- });
- });
- },
- pullSync: function (numBytes) {
- var slize = blob.slice(pos, pos + numBytes);
- pos += numBytes;
- var jsonPart = readBlobSync(slize, 'text');
- var result = parser.write(jsonPart);
- rv.result = result || {};
- return result;
- },
- done: function () {
- return parser.done();
- },
- eof: function () {
- return pos >= blob.size;
- },
- result: {}
- };
- return rv;
- }
- function JsonParser(allowPartial) {
- var parser = clarinet_1.parser();
- var level = 0;
- var result;
- var stack = [];
- var obj;
- var key;
- var done = false;
- var array = false;
- parser.onopenobject = function (newKey) {
- var newObj = {};
- newObj.incomplete = true;
- if (!result)
- result = newObj;
- if (obj) {
- stack.push([key, obj, array]);
- if (allowPartial) {
- if (array) {
- obj.push(newObj);
- }
- else {
- obj[key] = newObj;
- }
- }
- }
- obj = newObj;
- key = newKey;
- array = false;
- ++level;
- };
- parser.onkey = function (newKey) { return key = newKey; };
- parser.onvalue = function (value) { return array ? obj.push(value) : obj[key] = value; };
- parser.oncloseobject = function () {
- var _a;
- delete obj.incomplete;
- key = null;
- if (--level === 0) {
- done = true;
- }
- else {
- var completedObj = obj;
- _a = stack.pop(), key = _a[0], obj = _a[1], array = _a[2];
- if (!allowPartial) {
- if (array) {
- obj.push(completedObj);
- }
- else {
- obj[key] = completedObj;
- }
- }
- }
- };
- parser.onopenarray = function () {
- var newObj = [];
- newObj.incomplete = true;
- if (!result)
- result = newObj;
- if (obj) {
- stack.push([key, obj, array]);
- if (allowPartial) {
- if (array) {
- obj.push(newObj);
- }
- else {
- obj[key] = newObj;
- }
- }
- }
- obj = newObj;
- array = true;
- key = null;
- ++level;
- };
- parser.onclosearray = function () {
- var _a;
- delete obj.incomplete;
- key = null;
- if (--level === 0) {
- done = true;
- }
- else {
- var completedObj = obj;
- _a = stack.pop(), key = _a[0], obj = _a[1], array = _a[2];
- if (!allowPartial) {
- if (array) {
- obj.push(completedObj);
- }
- else {
- obj[key] = completedObj;
- }
- }
- }
- };
- return {
- write: function (jsonPart) {
- parser.write(jsonPart);
- return result;
- },
- done: function () {
- return done;
- }
- };
- }
-
- var DEFAULT_KILOBYTES_PER_CHUNK = 1024;
- function importDB(exportedData, options) {
- return __awaiter(this, void 0, void 0, function () {
- var CHUNK_SIZE, stream, dbExport, db;
- return __generator(this, function (_a) {
- switch (_a.label) {
- case 0:
- options = options || {}; // All booleans defaults to false.
- CHUNK_SIZE = options.chunkSizeBytes || (DEFAULT_KILOBYTES_PER_CHUNK * 1024);
- return [4 /*yield*/, loadUntilWeGotEnoughData(exportedData, CHUNK_SIZE)];
- case 1:
- stream = _a.sent();
- dbExport = stream.result.data;
- db = new Dexie__default["default"](dbExport.databaseName);
- db.version(dbExport.databaseVersion).stores(extractDbSchema(dbExport));
- return [4 /*yield*/, importInto(db, stream, options)];
- case 2:
- _a.sent();
- return [2 /*return*/, db];
- }
- });
- });
- }
- function peakImportFile(exportedData) {
- return __awaiter(this, void 0, void 0, function () {
- var stream;
- return __generator(this, function (_a) {
- switch (_a.label) {
- case 0:
- stream = JsonStream(exportedData);
- _a.label = 1;
- case 1:
- if (!!stream.eof()) return [3 /*break*/, 3];
- return [4 /*yield*/, stream.pullAsync(5 * 1024)];
- case 2:
- _a.sent(); // 5 k is normally enough for the headers. If not, it will just do another go.
- if (stream.result.data && stream.result.data.data) {
- // @ts-ignore - TS won't allow us to delete a required property - but we are going to cast it.
- delete stream.result.data.data; // Don't return half-baked data array.
- return [3 /*break*/, 3];
- }
- return [3 /*break*/, 1];
- case 3: return [2 /*return*/, stream.result];
- }
- });
- });
- }
- function importInto(db, exportedData, options) {
- return __awaiter(this, void 0, void 0, function () {
- function importAll() {
- return __awaiter(this, void 0, void 0, function () {
- var _loop_1, _i, _a, tableExport, state_1;
- return __generator(this, function (_b) {
- switch (_b.label) {
- case 0:
- _loop_1 = function (tableExport) {
- var tableName, table, tableSchemaStr, sourceRows, rows, i, obj, filter, filteredRows, _c, keys, values;
- return __generator(this, function (_d) {
- switch (_d.label) {
- case 0:
- if (!tableExport.rows)
- return [2 /*return*/, "break"]; // Need to pull more!
- if (!tableExport.rows.incomplete && tableExport.rows.length === 0)
- return [2 /*return*/, "continue"];
- if (progressCallback) {
- // Keep ongoing transaction private
- Dexie__default["default"].ignoreTransaction(function () { return progressCallback(progress); });
- }
- tableName = tableExport.tableName;
- table = db.table(tableName);
- tableSchemaStr = dbExport.tables.filter(function (t) { return t.name === tableName; })[0].schema;
- if (!table) {
- if (!options.acceptMissingTables)
- throw new Error("Exported table ".concat(tableExport.tableName, " is missing in installed database"));
- else
- return [2 /*return*/, "continue"];
- }
- if (!options.acceptChangedPrimaryKey &&
- tableSchemaStr.split(',')[0] != table.schema.primKey.src) {
- throw new Error("Primary key differs for table ".concat(tableExport.tableName, ". "));
- }
- sourceRows = tableExport.rows;
- rows = [];
- for (i = 0; i < sourceRows.length; i++) {
- obj = sourceRows[i];
- if (!obj.incomplete) {
- rows.push(TSON.revive(obj));
- }
- else {
- break;
- }
- }
- filter = options.filter;
- filteredRows = filter ?
- tableExport.inbound ?
- rows.filter(function (value) { return filter(tableName, value); }) :
- rows.filter(function (_a) {
- var key = _a[0], value = _a[1];
- return filter(tableName, value, key);
- }) :
- rows;
- _c = tableExport.inbound ?
- [undefined, filteredRows] :
- [filteredRows.map(function (row) { return row[0]; }), rows.map(function (row) { return row[1]; })], keys = _c[0], values = _c[1];
- if (!options.overwriteValues) return [3 /*break*/, 2];
- return [4 /*yield*/, table.bulkPut(values, keys)];
- case 1:
- _d.sent();
- return [3 /*break*/, 4];
- case 2: return [4 /*yield*/, table.bulkAdd(values, keys)];
- case 3:
- _d.sent();
- _d.label = 4;
- case 4:
- progress.completedRows += rows.length;
- if (!rows.incomplete) {
- progress.completedTables += 1;
- }
- sourceRows.splice(0, rows.length); // Free up RAM, keep existing array instance.
- return [2 /*return*/];
- }
- });
- };
- _i = 0, _a = dbExport.data;
- _b.label = 1;
- case 1:
- if (!(_i < _a.length)) return [3 /*break*/, 4];
- tableExport = _a[_i];
- return [5 /*yield**/, _loop_1(tableExport)];
- case 2:
- state_1 = _b.sent();
- if (state_1 === "break")
- return [3 /*break*/, 4];
- _b.label = 3;
- case 3:
- _i++;
- return [3 /*break*/, 1];
- case 4:
- // Avoid unnescessary loops in "for (const tableExport of dbExport.data)"
- while (dbExport.data.length > 0 && dbExport.data[0].rows && !dbExport.data[0].rows.incomplete) {
- // We've already imported all rows from the first table. Delete its occurrence
- dbExport.data.splice(0, 1);
- }
- if (!(!jsonStream.done() && !jsonStream.eof())) return [3 /*break*/, 8];
- if (!readBlobsSynchronously) return [3 /*break*/, 5];
- // If we can pull from blob synchronically, we don't have to
- // keep transaction alive using Dexie.waitFor().
- // This will only be possible in workers.
- jsonStream.pullSync(CHUNK_SIZE);
- return [3 /*break*/, 7];
- case 5: return [4 /*yield*/, Dexie__default["default"].waitFor(jsonStream.pullAsync(CHUNK_SIZE))];
- case 6:
- _b.sent();
- _b.label = 7;
- case 7: return [3 /*break*/, 9];
- case 8: return [3 /*break*/, 10];
- case 9:
- return [3 /*break*/, 0];
- case 10: return [2 /*return*/];
- }
- });
- });
- }
- var CHUNK_SIZE, jsonStream, dbExportFile, readBlobsSynchronously, dbExport, progressCallback, progress, _i, _a, table;
- return __generator(this, function (_b) {
- switch (_b.label) {
- case 0:
- options = options || {}; // All booleans defaults to false.
- CHUNK_SIZE = options.chunkSizeBytes || (DEFAULT_KILOBYTES_PER_CHUNK * 1024);
- return [4 /*yield*/, loadUntilWeGotEnoughData(exportedData, CHUNK_SIZE)];
- case 1:
- jsonStream = _b.sent();
- dbExportFile = jsonStream.result;
- readBlobsSynchronously = 'FileReaderSync' in self;
- dbExport = dbExportFile.data;
- if (!options.acceptNameDiff && db.name !== dbExport.databaseName)
- throw new Error("Name differs. Current database name is ".concat(db.name, " but export is ").concat(dbExport.databaseName));
- if (!options.acceptVersionDiff && db.verno !== dbExport.databaseVersion) {
- // Possible feature: Call upgraders in some isolated way if this happens... ?
- throw new Error("Database version differs. Current database is in version ".concat(db.verno, " but export is ").concat(dbExport.databaseVersion));
- }
- progressCallback = options.progressCallback;
- progress = {
- done: false,
- completedRows: 0,
- completedTables: 0,
- totalRows: dbExport.tables.reduce(function (p, c) { return p + c.rowCount; }, 0),
- totalTables: dbExport.tables.length
- };
- if (progressCallback) {
- // Keep ongoing transaction private
- Dexie__default["default"].ignoreTransaction(function () { return progressCallback(progress); });
- }
- if (!options.clearTablesBeforeImport) return [3 /*break*/, 5];
- _i = 0, _a = db.tables;
- _b.label = 2;
- case 2:
- if (!(_i < _a.length)) return [3 /*break*/, 5];
- table = _a[_i];
- return [4 /*yield*/, table.clear()];
- case 3:
- _b.sent();
- _b.label = 4;
- case 4:
- _i++;
- return [3 /*break*/, 2];
- case 5:
- if (!options.noTransaction) return [3 /*break*/, 7];
- return [4 /*yield*/, importAll()];
- case 6:
- _b.sent();
- return [3 /*break*/, 9];
- case 7: return [4 /*yield*/, db.transaction('rw', db.tables, importAll)];
- case 8:
- _b.sent();
- _b.label = 9;
- case 9:
- progress.done = true;
- if (progressCallback) {
- // Keep ongoing transaction private
- Dexie__default["default"].ignoreTransaction(function () { return progressCallback(progress); });
- }
- return [2 /*return*/];
- }
- });
- });
- }
- function loadUntilWeGotEnoughData(exportedData, CHUNK_SIZE) {
- return __awaiter(this, void 0, void 0, function () {
- var stream, dbExportFile;
- return __generator(this, function (_a) {
- switch (_a.label) {
- case 0:
- stream = ('slice' in exportedData ?
- JsonStream(exportedData) :
- exportedData);
- _a.label = 1;
- case 1:
- if (!!stream.eof()) return [3 /*break*/, 3];
- return [4 /*yield*/, stream.pullAsync(CHUNK_SIZE)];
- case 2:
- _a.sent();
- if (stream.result.data && stream.result.data.data)
- return [3 /*break*/, 3];
- return [3 /*break*/, 1];
- case 3:
- dbExportFile = stream.result;
- if (!dbExportFile || dbExportFile.formatName != "dexie")
- throw new Error("Given file is not a dexie export");
- if (dbExportFile.formatVersion > VERSION) {
- throw new Error("Format version ".concat(dbExportFile.formatVersion, " not supported"));
- }
- if (!dbExportFile.data) {
- throw new Error("No data in export file");
- }
- if (!dbExportFile.data.databaseName) {
- throw new Error("Missing databaseName in export file");
- }
- if (!dbExportFile.data.databaseVersion) {
- throw new Error("Missing databaseVersion in export file");
- }
- if (!dbExportFile.data.tables) {
- throw new Error("Missing tables in export file");
- }
- return [2 /*return*/, stream];
- }
- });
- });
- }
-
- //
- // Extend Dexie interface (runtime wise)
- //
- Dexie__default["default"].prototype.export = function (options) {
- return exportDB(this, options);
- };
- Dexie__default["default"].prototype.import = function (blob, options) {
- return importInto(this, blob, options);
- };
- Dexie__default["default"].import = function (blob, options) { return importDB(blob, options); };
- var dexieExportImport = (function () {
- throw new Error("This addon extends Dexie.prototype globally and does not have be included in Dexie constructor's addons options.");
- });
-
- exports["default"] = dexieExportImport;
- exports.exportDB = exportDB;
- exports.importDB = importDB;
- exports.importInto = importInto;
- exports.peakImportFile = peakImportFile;
-
- Object.defineProperty(exports, '__esModule', { value: true });
-
-}));
-//# sourceMappingURL=dexie-export-import.js.map