🚀 Big News:Socket Has Acquired Secure Annex.Learn More →
json-stream-stringify
Advanced tools
json-stream-stringify - npm Package Compare versions
+554
| import { Readable } from 'stream'; | ||
| 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 _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 _inherits(subClass, superClass) { | ||
| if (typeof superClass !== "function" && superClass !== null) { | ||
| throw new TypeError("Super expression must either be null or a function"); | ||
| } | ||
| subClass.prototype = Object.create(superClass && superClass.prototype, { | ||
| constructor: { | ||
| value: subClass, | ||
| writable: true, | ||
| configurable: true | ||
| } | ||
| }); | ||
| if (superClass) _setPrototypeOf(subClass, superClass); | ||
| } | ||
| function _getPrototypeOf(o) { | ||
| _getPrototypeOf = Object.setPrototypeOf ? Object.getPrototypeOf : function _getPrototypeOf(o) { | ||
| return o.__proto__ || Object.getPrototypeOf(o); | ||
| }; | ||
| return _getPrototypeOf(o); | ||
| } | ||
| function _setPrototypeOf(o, p) { | ||
| _setPrototypeOf = Object.setPrototypeOf || function _setPrototypeOf(o, p) { | ||
| o.__proto__ = p; | ||
| return o; | ||
| }; | ||
| return _setPrototypeOf(o, p); | ||
| } | ||
| function _assertThisInitialized(self) { | ||
| if (self === void 0) { | ||
| throw new ReferenceError("this hasn't been initialised - super() hasn't been called"); | ||
| } | ||
| return self; | ||
| } | ||
| function _possibleConstructorReturn(self, call) { | ||
| if (call && (typeof call === "object" || typeof call === "function")) { | ||
| return call; | ||
| } | ||
| return _assertThisInitialized(self); | ||
| } | ||
| var rxEscapable = /[\\"\u0000-\u001f\u007f-\u009f\u00ad\u0600-\u0604\u070f\u17b4\u17b5\u200c-\u200f\u2028-\u202f\u2060-\u206f\ufeff\ufff0-\uffff]/g; // table of character substitutions | ||
| var meta = { | ||
| '\b': '\\b', | ||
| '\t': '\\t', | ||
| '\n': '\\n', | ||
| '\f': '\\f', | ||
| '\r': '\\r', | ||
| '"': '\\"', | ||
| '\\': '\\\\' | ||
| }; | ||
| function isReadableStream(value) { | ||
| return typeof value.read === 'function' && typeof value.once === 'function' && typeof value.removeListener === 'function' && _typeof(value._readableState) === 'object'; | ||
| } | ||
| function getType(value) { | ||
| if (!value) return 'Primitive'; | ||
| if (typeof value.then === 'function') return 'Promise'; | ||
| if (isReadableStream(value)) return "Readable".concat(value._readableState.objectMode ? 'Object' : 'String'); | ||
| if (Array.isArray(value)) return 'Array'; | ||
| if (_typeof(value) === 'object' || value instanceof Object) return 'Object'; | ||
| return 'Primitive'; | ||
| } | ||
| var stackItemEnd = { | ||
| Array: ']', | ||
| Object: '}', | ||
| ReadableString: '"', | ||
| ReadableObject: ']' | ||
| }; | ||
| var stackItemOpen = { | ||
| Array: '[', | ||
| Object: '{', | ||
| ReadableString: '"', | ||
| ReadableObject: '[' | ||
| }; | ||
| function escapeString(string) { | ||
| // Modified code, original code by Douglas Crockford | ||
| // Original: https://github.com/douglascrockford/JSON-js/blob/master/json2.js | ||
| // If the string contains no control characters, no quote characters, and no | ||
| // backslash characters, then we can safely slap some quotes around it. | ||
| // Otherwise we must also replace the offending characters with safe escape | ||
| // sequences. | ||
| return string.replace(rxEscapable, function (a) { | ||
| var c = meta[a]; | ||
| return typeof c === 'string' ? c : "\\u".concat(a.charCodeAt(0).toString(16).padStart(4, '0')); | ||
| }); | ||
| } | ||
| function quoteString(string) { | ||
| return "\"".concat(escapeString(string), "\""); | ||
| } | ||
| function readAsPromised(stream, size) { | ||
| var value = stream.read(size); | ||
| if (value === null) { | ||
| return new Promise(function (resolve, reject) { | ||
| var endListener = function endListener() { | ||
| return resolve(null); | ||
| }; | ||
| stream.once('end', endListener); | ||
| stream.once('error', reject); | ||
| stream.once('readable', function () { | ||
| stream.removeListener('end', endListener); | ||
| stream.removeListener('error', reject); | ||
| resolve(stream.read()); | ||
| }); | ||
| }); | ||
| } | ||
| return Promise.resolve(value); | ||
| } | ||
| function recursiveResolve(promise) { | ||
| return promise.then(function (res) { | ||
| var resType = getType(res); | ||
| return resType === 'Promise' ? recursiveResolve(res) : res; | ||
| }); | ||
| } | ||
| var JsonStreamStringify = | ||
| /*#__PURE__*/ | ||
| function (_Readable) { | ||
| _inherits(JsonStreamStringify, _Readable); | ||
| function JsonStreamStringify(value, replacer, spaces, cycle) { | ||
| var _this; | ||
| _classCallCheck(this, JsonStreamStringify); | ||
| _this = _possibleConstructorReturn(this, _getPrototypeOf(JsonStreamStringify).call(this, {})); | ||
| var gap; | ||
| var spaceType = _typeof(spaces); | ||
| if (spaceType === 'string' || spaceType === 'number') { | ||
| gap = Number.isFinite(spaces) ? ' '.repeat(spaces) : spaces; | ||
| } | ||
| Object.assign(_assertThisInitialized(_assertThisInitialized(_this)), { | ||
| visited: cycle ? new WeakMap() : new WeakSet(), | ||
| cycle: cycle, | ||
| stack: [], | ||
| replacerFunction: replacer instanceof Function && replacer, | ||
| replacerArray: Array.isArray(replacer) && replacer, | ||
| gap: gap, | ||
| depth: 0 | ||
| }); | ||
| _this.addToStack(value); | ||
| return _this; | ||
| } | ||
| _createClass(JsonStreamStringify, [{ | ||
| key: "cycler", | ||
| value: function cycler(key, value) { | ||
| var existingPath = this.visited.get(value); | ||
| if (existingPath) { | ||
| return { | ||
| $ref: existingPath | ||
| }; | ||
| } | ||
| var path = this.path(); | ||
| if (key !== undefined) path.push(key); | ||
| path = path.map(function (v) { | ||
| return "[".concat(Number.isInteger(v) ? v : quoteString(v), "]"); | ||
| }); | ||
| this.visited.set(value, path.length ? "$".concat(path.join('')) : '$'); | ||
| return value; | ||
| } | ||
| }, { | ||
| key: "addToStack", | ||
| value: function addToStack(value, key, index) { | ||
| var _this2 = this; | ||
| var realValue = value; | ||
| if (this.replacerFunction) { | ||
| realValue = this.replacerFunction(key || index, realValue, this); | ||
| } // ORDER? | ||
| if (realValue && realValue.toJSON instanceof Function) { | ||
| realValue = realValue.toJSON(); | ||
| } | ||
| if (realValue instanceof Function || _typeof(value) === 'symbol') { | ||
| realValue = undefined; | ||
| } | ||
| if (key !== undefined && this.replacerArray) { | ||
| if (!this.replacerArray.includes(key)) { | ||
| realValue = undefined; | ||
| } | ||
| } | ||
| var type = getType(realValue); | ||
| if (realValue !== undefined && type !== 'Promise' && key) { | ||
| if (this.gap) { | ||
| this._push("\n".concat(this.gap.repeat(this.depth), "\"").concat(escapeString(key), "\": ")); | ||
| } else { | ||
| this._push("\"".concat(escapeString(key), "\":")); | ||
| } | ||
| } | ||
| if (type !== 'Primitive') { | ||
| if (this.cycle) { | ||
| // run cycler | ||
| realValue = this.cycler(key || index, realValue); | ||
| type = getType(realValue); | ||
| } else { | ||
| // check for circular structure | ||
| if (this.visited.has(realValue)) { | ||
| throw Object.assign(new Error('Converting circular structure to JSON'), { | ||
| realValue: realValue, | ||
| key: key || index | ||
| }); | ||
| } | ||
| this.visited.add(realValue); | ||
| } | ||
| } | ||
| if (!key && index > -1 && this.depth && this.gap) this._push("\n".concat(this.gap.repeat(this.depth))); | ||
| var open = stackItemOpen[type]; | ||
| if (open) this._push(open); | ||
| var obj = { | ||
| key: key, | ||
| index: index, | ||
| type: type, | ||
| value: realValue | ||
| }; | ||
| if (type === 'Object') { | ||
| this.depth += 1; | ||
| obj.unread = Object.keys(realValue); | ||
| obj.isEmpty = !obj.unread.length; | ||
| } else if (type === 'Array') { | ||
| this.depth += 1; | ||
| obj.unread = Array.from(Array(realValue.length).keys()); | ||
| obj.isEmpty = !obj.unread.length; | ||
| } else if (type.startsWith('Readable')) { | ||
| this.depth += 1; | ||
| if (realValue._readableState.ended) { | ||
| this.emit('error', new Error('Readable Stream has ended before it was serialized. All stream data have been lost'), realValue, key || index); | ||
| } else if (realValue._readableState.flowing) { | ||
| realValue.pause(); | ||
| this.emit('error', new Error('Readable Stream is in flowing mode, data may have been lost. Trying to pause stream.'), realValue, key || index); | ||
| } | ||
| obj.readCount = 0; | ||
| realValue.once('end', function () { | ||
| obj.end = true; | ||
| _this2.__read(); | ||
| }); | ||
| realValue.once('error', function (err) { | ||
| _this2.error = true; | ||
| _this2.emit('error', err); | ||
| }); | ||
| obj.first = true; | ||
| } | ||
| this.stack.unshift(obj); | ||
| return obj; | ||
| } | ||
| }, { | ||
| key: "removeFromStack", | ||
| value: function removeFromStack(item) { | ||
| var type = item.type; | ||
| var isObject = type === 'Object' || type === 'Array' || type.startsWith('Readable'); | ||
| if (type !== 'Primitive') { | ||
| if (!this.cycle) { | ||
| this.visited.delete(item.value); | ||
| } | ||
| if (isObject) { | ||
| this.depth -= 1; | ||
| } | ||
| } | ||
| var end = stackItemEnd[type]; | ||
| if (isObject && !item.isEmpty && this.gap) this._push("\n".concat(this.gap.repeat(this.depth))); | ||
| if (end) this._push(end); | ||
| if (item.addSeparatorAfterEnd) { | ||
| this._push(','); | ||
| } | ||
| this.stack.splice(this.stack.indexOf(item), 1); | ||
| } | ||
| }, { | ||
| key: "_push", | ||
| value: function _push(data) { | ||
| this.pushCalled = true; | ||
| this.push(data); | ||
| } | ||
| }, { | ||
| key: "processReadableObject", | ||
| value: function processReadableObject(current, size) { | ||
| var _this3 = this; | ||
| if (current.end) { | ||
| this.removeFromStack(current); | ||
| return undefined; | ||
| } | ||
| return readAsPromised(current.value, size).then(function (value) { | ||
| if (value !== null) { | ||
| if (!current.first) { | ||
| _this3._push(','); | ||
| } | ||
| /* eslint-disable no-param-reassign */ | ||
| current.first = false; | ||
| _this3.addToStack(value, undefined, current.readCount); | ||
| current.readCount += 1; | ||
| /* eslint-enable no-param-reassign */ | ||
| } | ||
| }); | ||
| } | ||
| }, { | ||
| key: "processObject", | ||
| value: function processObject(current) { | ||
| if (!current.unread.length) { | ||
| this.removeFromStack(current); | ||
| return; | ||
| } | ||
| var key = current.unread.shift(); | ||
| var value = current.value[key]; | ||
| this.addToStack(value, current.type === 'Object' && key, current.type === 'Array' && key).addSeparatorAfterEnd = !!current.unread.length; | ||
| } | ||
| }, { | ||
| key: "processArray", | ||
| value: function processArray(current) { | ||
| return this.processObject(current); | ||
| } | ||
| }, { | ||
| key: "processPrimitive", | ||
| value: function processPrimitive(current) { | ||
| if (current.value !== undefined) { | ||
| var type = _typeof(current.value); | ||
| var value; | ||
| switch (type) { | ||
| case 'string': | ||
| value = quoteString(current.value); | ||
| break; | ||
| case 'number': | ||
| value = Number.isFinite(current.value) ? String(current.value) : 'null'; | ||
| break; | ||
| case 'boolean': | ||
| case 'null': | ||
| value = String(current.value); | ||
| break; | ||
| case 'object': | ||
| if (!current.value) { | ||
| value = 'null'; | ||
| break; | ||
| } | ||
| /* eslint-disable-next-line no-fallthrough */ | ||
| default: | ||
| // This should never happen, I can't imagine a situation where this executes. | ||
| // If you find a way, please open a ticket or PR | ||
| throw Object.assign(new Error("Unknown type \"".concat(type, "\". Please file an issue!")), { | ||
| value: current.value | ||
| }); | ||
| } | ||
| this._push(value); | ||
| } else if (this.stack[1] && (this.stack[1].type === 'Array' || this.stack[1].type === 'ReadableObject')) { | ||
| this._push('null'); | ||
| } else { | ||
| /* eslint-disable-next-line no-param-reassign */ | ||
| current.addSeparatorAfterEnd = false; | ||
| } | ||
| this.removeFromStack(current); | ||
| } | ||
| }, { | ||
| key: "processReadableString", | ||
| value: function processReadableString(current, size) { | ||
| var _this4 = this; | ||
| if (current.end) { | ||
| this.removeFromStack(current); | ||
| return undefined; | ||
| } | ||
| return readAsPromised(current.value, size).then(function (value) { | ||
| if (value) _this4._push(escapeString(value.toString())); | ||
| }); | ||
| } | ||
| }, { | ||
| key: "processPromise", | ||
| value: function processPromise(current) { | ||
| var _this5 = this; | ||
| return recursiveResolve(current.value).then(function (value) { | ||
| var addSeparatorAfterEnd = current.addSeparatorAfterEnd; | ||
| /* eslint-disable-next-line no-param-reassign */ | ||
| current.addSeparatorAfterEnd = false; | ||
| _this5.removeFromStack(current); | ||
| _this5.addToStack(value, current.key, current.index).addSeparatorAfterEnd = addSeparatorAfterEnd; | ||
| }); | ||
| } | ||
| }, { | ||
| key: "processStackTopItem", | ||
| value: function processStackTopItem(size) { | ||
| var _this6 = this; | ||
| var current = this.stack[0]; | ||
| if (!current || this.error) return Promise.resolve(); | ||
| var out; | ||
| try { | ||
| out = this["process".concat(current.type)](current, size); | ||
| } catch (err) { | ||
| return Promise.reject(err); | ||
| } | ||
| return Promise.resolve(out).then(function () { | ||
| if (_this6.stack.length === 0) { | ||
| _this6.end = true; | ||
| _this6._push(null); | ||
| } | ||
| }); | ||
| } | ||
| }, { | ||
| key: "__read", | ||
| value: function __read(size) { | ||
| var _this7 = this; | ||
| if (this.isRunning || this.error) { | ||
| this.readMore = true; | ||
| return undefined; | ||
| } | ||
| this.isRunning = true; // we must continue to read while push has not been called | ||
| this.readMore = false; | ||
| return this.processStackTopItem(size).then(function () { | ||
| var readAgain = !_this7.end && !_this7.error && (_this7.readMore || !_this7.pushCalled); | ||
| if (readAgain) { | ||
| setImmediate(function () { | ||
| _this7.isRunning = false; | ||
| _this7.__read(); | ||
| }); | ||
| } else { | ||
| _this7.isRunning = false; | ||
| } | ||
| }).catch(function (err) { | ||
| _this7.error = true; | ||
| _this7.emit('error', err); | ||
| }); | ||
| } | ||
| }, { | ||
| key: "_read", | ||
| value: function _read(size) { | ||
| this.pushCalled = false; | ||
| this.__read(size); | ||
| } | ||
| }, { | ||
| key: "path", | ||
| value: function path() { | ||
| return this.stack.map(function (_ref) { | ||
| var key = _ref.key, | ||
| index = _ref.index; | ||
| return key || index; | ||
| }).filter(function (v) { | ||
| return v || v > -1; | ||
| }).reverse(); | ||
| } | ||
| }]); | ||
| return JsonStreamStringify; | ||
| }(Readable); | ||
| export default JsonStreamStringify; | ||
| //# sourceMappingURL=module.js.map |
| {"version":3,"file":"module.js","sources":["../src/JsonStreamStringify.js"],"sourcesContent":["import { Readable } from 'stream';\n\nconst rxEscapable = /[\\\\\"\\u0000-\\u001f\\u007f-\\u009f\\u00ad\\u0600-\\u0604\\u070f\\u17b4\\u17b5\\u200c-\\u200f\\u2028-\\u202f\\u2060-\\u206f\\ufeff\\ufff0-\\uffff]/g;\n\n// table of character substitutions\nconst meta = {\n '\\b': '\\\\b',\n '\\t': '\\\\t',\n '\\n': '\\\\n',\n '\\f': '\\\\f',\n '\\r': '\\\\r',\n '\"': '\\\\\"',\n '\\\\': '\\\\\\\\',\n};\n\nfunction isReadableStream(value) {\n return typeof value.read === 'function'\n && typeof value.once === 'function'\n && typeof value.removeListener === 'function'\n && typeof value._readableState === 'object';\n}\n\nfunction getType(value) {\n if (!value) return 'Primitive';\n if (typeof value.then === 'function') return 'Promise';\n if (isReadableStream(value)) return `Readable${value._readableState.objectMode ? 'Object' : 'String'}`;\n if (Array.isArray(value)) return 'Array';\n if (typeof value === 'object' || value instanceof Object) return 'Object';\n return 'Primitive';\n}\n\nconst stackItemEnd = {\n Array: ']',\n Object: '}',\n ReadableString: '\"',\n ReadableObject: ']',\n};\n\nconst stackItemOpen = {\n Array: '[',\n Object: '{',\n ReadableString: '\"',\n ReadableObject: '[',\n};\n\nfunction escapeString(string) {\n // Modified code, original code by Douglas Crockford\n // Original: https://github.com/douglascrockford/JSON-js/blob/master/json2.js\n\n // If the string contains no control characters, no quote characters, and no\n // backslash characters, then we can safely slap some quotes around it.\n // Otherwise we must also replace the offending characters with safe escape\n // sequences.\n\n return string.replace(rxEscapable, (a) => {\n const c = meta[a];\n return typeof c === 'string' ? c : `\\\\u${a.charCodeAt(0).toString(16).padStart(4, '0')}`;\n });\n}\n\nfunction quoteString(string) {\n return `\"${escapeString(string)}\"`;\n}\n\nfunction readAsPromised(stream, size) {\n const value = stream.read(size);\n if (value === null) {\n return new Promise((resolve, reject) => {\n const endListener = () => resolve(null);\n stream.once('end', endListener);\n stream.once('error', reject);\n stream.once('readable', () => {\n stream.removeListener('end', endListener);\n stream.removeListener('error', reject);\n resolve(stream.read());\n });\n });\n }\n return Promise.resolve(value);\n}\n\nfunction recursiveResolve(promise) {\n return promise.then((res) => {\n const resType = getType(res);\n return resType === 'Promise' ? recursiveResolve(res) : res;\n });\n}\n\nclass JsonStreamStringify extends Readable {\n constructor(value, replacer, spaces, cycle) {\n super({});\n let gap;\n const spaceType = typeof spaces;\n if (spaceType === 'string' || spaceType === 'number') {\n gap = Number.isFinite(spaces) ? ' '.repeat(spaces) : spaces;\n }\n Object.assign(this, {\n visited: cycle ? new WeakMap() : new WeakSet(),\n cycle,\n stack: [],\n replacerFunction: replacer instanceof Function && replacer,\n replacerArray: Array.isArray(replacer) && replacer,\n gap,\n depth: 0,\n });\n this.addToStack(value);\n }\n\n cycler(key, value) {\n const existingPath = this.visited.get(value);\n if (existingPath) {\n return {\n $ref: existingPath,\n };\n }\n let path = this.path();\n if (key !== undefined) path.push(key);\n path = path.map(v => `[${(Number.isInteger(v) ? v : quoteString(v))}]`);\n this.visited.set(value, path.length ? `$${path.join('')}` : '$');\n return value;\n }\n\n addToStack(value, key, index) {\n let realValue = value;\n if (this.replacerFunction) {\n realValue = this.replacerFunction(key || index, realValue, this);\n }\n // ORDER?\n if (realValue && realValue.toJSON instanceof Function) {\n realValue = realValue.toJSON();\n }\n if (realValue instanceof Function || typeof value === 'symbol') {\n realValue = undefined;\n }\n if (key !== undefined && this.replacerArray) {\n if (!this.replacerArray.includes(key)) {\n realValue = undefined;\n }\n }\n let type = getType(realValue);\n if (realValue !== undefined && type !== 'Promise' && key) {\n if (this.gap) {\n this._push(`\\n${this.gap.repeat(this.depth)}\"${escapeString(key)}\": `);\n } else {\n this._push(`\"${escapeString(key)}\":`);\n }\n }\n if (type !== 'Primitive') {\n if (this.cycle) {\n // run cycler\n realValue = this.cycler(key || index, realValue);\n type = getType(realValue);\n } else {\n // check for circular structure\n if (this.visited.has(realValue)) {\n throw Object.assign(new Error('Converting circular structure to JSON'), {\n realValue,\n key: key || index,\n });\n }\n this.visited.add(realValue);\n }\n }\n\n if (!key && index > -1 && this.depth && this.gap) this._push(`\\n${this.gap.repeat(this.depth)}`);\n\n const open = stackItemOpen[type];\n if (open) this._push(open);\n\n const obj = {\n key,\n index,\n type,\n value: realValue,\n };\n\n if (type === 'Object') {\n this.depth += 1;\n obj.unread = Object.keys(realValue);\n obj.isEmpty = !obj.unread.length;\n } else if (type === 'Array') {\n this.depth += 1;\n obj.unread = Array.from(Array(realValue.length).keys());\n obj.isEmpty = !obj.unread.length;\n } else if (type.startsWith('Readable')) {\n this.depth += 1;\n if (realValue._readableState.ended) {\n this.emit('error', new Error('Readable Stream has ended before it was serialized. All stream data have been lost'), realValue, key || index);\n } else if (realValue._readableState.flowing) {\n realValue.pause();\n this.emit('error', new Error('Readable Stream is in flowing mode, data may have been lost. Trying to pause stream.'), realValue, key || index);\n }\n obj.readCount = 0;\n realValue.once('end', () => {\n obj.end = true;\n this.__read();\n });\n realValue.once('error', (err) => {\n this.error = true;\n this.emit('error', err);\n });\n obj.first = true;\n }\n this.stack.unshift(obj);\n return obj;\n }\n\n removeFromStack(item) {\n const {\n type,\n } = item;\n const isObject = type === 'Object' || type === 'Array' || type.startsWith('Readable');\n if (type !== 'Primitive') {\n if (!this.cycle) {\n this.visited.delete(item.value);\n }\n if (isObject) {\n this.depth -= 1;\n }\n }\n\n const end = stackItemEnd[type];\n if (isObject && !item.isEmpty && this.gap) this._push(`\\n${this.gap.repeat(this.depth)}`);\n if (end) this._push(end);\n if (item.addSeparatorAfterEnd) {\n this._push(',');\n }\n this.stack.splice(this.stack.indexOf(item), 1);\n }\n\n _push(data) {\n this.pushCalled = true;\n this.push(data);\n }\n\n processReadableObject(current, size) {\n if (current.end) {\n this.removeFromStack(current);\n return undefined;\n }\n return readAsPromised(current.value, size)\n .then((value) => {\n if (value !== null) {\n if (!current.first) {\n this._push(',');\n }\n /* eslint-disable no-param-reassign */\n current.first = false;\n this.addToStack(value, undefined, current.readCount);\n current.readCount += 1;\n /* eslint-enable no-param-reassign */\n }\n });\n }\n\n processObject(current) {\n if (!current.unread.length) {\n this.removeFromStack(current);\n return;\n }\n const key = current.unread.shift();\n const value = current.value[key];\n\n this.addToStack(value, current.type === 'Object' && key, current.type === 'Array' && key).addSeparatorAfterEnd = !!current.unread.length;\n }\n\n processArray(current) {\n return this.processObject(current);\n }\n\n processPrimitive(current) {\n if (current.value !== undefined) {\n const type = typeof current.value;\n let value;\n switch (type) {\n case 'string':\n value = quoteString(current.value);\n break;\n case 'number':\n value = Number.isFinite(current.value) ? String(current.value) : 'null';\n break;\n case 'boolean':\n case 'null':\n value = String(current.value);\n break;\n case 'object':\n if (!current.value) {\n value = 'null';\n break;\n }\n /* eslint-disable-next-line no-fallthrough */\n default:\n // This should never happen, I can't imagine a situation where this executes.\n // If you find a way, please open a ticket or PR\n throw Object.assign(new Error(`Unknown type \"${type}\". Please file an issue!`), {\n value: current.value,\n });\n }\n this._push(value);\n } else if (this.stack[1] && (this.stack[1].type === 'Array' || this.stack[1].type === 'ReadableObject')) {\n this._push('null');\n } else {\n /* eslint-disable-next-line no-param-reassign */\n current.addSeparatorAfterEnd = false;\n }\n this.removeFromStack(current);\n }\n\n processReadableString(current, size) {\n if (current.end) {\n this.removeFromStack(current);\n return undefined;\n }\n return readAsPromised(current.value, size)\n .then((value) => {\n if (value) this._push(escapeString(value.toString()));\n });\n }\n\n processPromise(current) {\n return recursiveResolve(current.value).then((value) => {\n const {\n addSeparatorAfterEnd,\n } = current;\n /* eslint-disable-next-line no-param-reassign */\n current.addSeparatorAfterEnd = false;\n this.removeFromStack(current);\n this.addToStack(value, current.key, current.index)\n .addSeparatorAfterEnd = addSeparatorAfterEnd;\n });\n }\n\n processStackTopItem(size) {\n const current = this.stack[0];\n if (!current || this.error) return Promise.resolve();\n let out;\n try {\n out = this[`process${current.type}`](current, size);\n } catch (err) {\n return Promise.reject(err);\n }\n return Promise.resolve(out)\n .then(() => {\n if (this.stack.length === 0) {\n this.end = true;\n this._push(null);\n }\n });\n }\n\n __read(size) {\n if (this.isRunning || this.error) {\n this.readMore = true;\n return undefined;\n }\n this.isRunning = true;\n\n // we must continue to read while push has not been called\n this.readMore = false;\n return this.processStackTopItem(size)\n .then(() => {\n const readAgain = !this.end && !this.error && (this.readMore || !this.pushCalled);\n if (readAgain) {\n setImmediate(() => {\n this.isRunning = false;\n this.__read();\n });\n } else {\n this.isRunning = false;\n }\n })\n .catch((err) => {\n this.error = true;\n this.emit('error', err);\n });\n }\n\n _read(size) {\n this.pushCalled = false;\n this.__read(size);\n }\n\n path() {\n return this.stack.map(({\n key,\n index,\n }) => key || index).filter(v => v || v > -1).reverse();\n }\n}\n\nexport default JsonStreamStringify;\n"],"names":["rxEscapable","meta","isReadableStream","value","read","once","removeListener","_readableState","getType","then","objectMode","Array","isArray","Object","stackItemEnd","stackItemOpen","escapeString","string","replace","a","c","charCodeAt","toString","padStart","quoteString","readAsPromised","stream","size","Promise","resolve","reject","endListener","recursiveResolve","promise","res","resType","JsonStreamStringify","replacer","spaces","cycle","gap","spaceType","Number","isFinite","repeat","assign","WeakMap","WeakSet","Function","addToStack","key","existingPath","visited","get","path","undefined","push","map","isInteger","v","set","length","join","index","realValue","replacerFunction","toJSON","replacerArray","includes","type","_push","depth","cycler","has","Error","add","open","obj","unread","keys","isEmpty","from","startsWith","ended","emit","flowing","pause","readCount","end","__read","err","error","first","stack","unshift","item","isObject","delete","addSeparatorAfterEnd","splice","indexOf","data","pushCalled","current","removeFromStack","shift","processObject","String","out","isRunning","readMore","processStackTopItem","readAgain","catch","filter","reverse","Readable"],"mappings":";;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;AAEA,IAAMA,cAAc,iIAApB;;AAGA,IAAMC,OAAO;QACL,KADK;QAEL,KAFK;QAGL,KAHK;QAIL,KAJK;QAKL,KALK;OAMN,KANM;QAOL;CAPR;;AAUA,SAASC,gBAAT,CAA0BC,KAA1B,EAAiC;SACxB,OAAOA,MAAMC,IAAb,KAAsB,UAAtB,IACE,OAAOD,MAAME,IAAb,KAAsB,UADxB,IAEE,OAAOF,MAAMG,cAAb,KAAgC,UAFlC,IAGE,QAAOH,MAAMI,cAAb,MAAgC,QAHzC;;;AAMF,SAASC,OAAT,CAAiBL,KAAjB,EAAwB;MAClB,CAACA,KAAL,EAAY,OAAO,WAAP;MACR,OAAOA,MAAMM,IAAb,KAAsB,UAA1B,EAAsC,OAAO,SAAP;MAClCP,iBAAiBC,KAAjB,CAAJ,EAA6B,yBAAkBA,MAAMI,cAAN,CAAqBG,UAArB,GAAkC,QAAlC,GAA6C,QAA/D;MACzBC,MAAMC,OAAN,CAAcT,KAAd,CAAJ,EAA0B,OAAO,OAAP;MACtB,QAAOA,KAAP,MAAiB,QAAjB,IAA6BA,iBAAiBU,MAAlD,EAA0D,OAAO,QAAP;SACnD,WAAP;;;AAGF,IAAMC,eAAe;SACZ,GADY;UAEX,GAFW;kBAGH,GAHG;kBAIH;CAJlB;AAOA,IAAMC,gBAAgB;SACb,GADa;UAEZ,GAFY;kBAGJ,GAHI;kBAIJ;CAJlB;;AAOA,SAASC,YAAT,CAAsBC,MAAtB,EAA8B;;;;;;;SASrBA,OAAOC,OAAP,CAAelB,WAAf,EAA4B,UAACmB,CAAD,EAAO;QAClCC,IAAInB,KAAKkB,CAAL,CAAV;WACO,OAAOC,CAAP,KAAa,QAAb,GAAwBA,CAAxB,gBAAkCD,EAAEE,UAAF,CAAa,CAAb,EAAgBC,QAAhB,CAAyB,EAAzB,EAA6BC,QAA7B,CAAsC,CAAtC,EAAyC,GAAzC,CAAlC,CAAP;GAFK,CAAP;;;AAMF,SAASC,WAAT,CAAqBP,MAArB,EAA6B;qBAChBD,aAAaC,MAAb,CAAX;;;AAGF,SAASQ,cAAT,CAAwBC,MAAxB,EAAgCC,IAAhC,EAAsC;MAC9BxB,QAAQuB,OAAOtB,IAAP,CAAYuB,IAAZ,CAAd;;MACIxB,UAAU,IAAd,EAAoB;WACX,IAAIyB,OAAJ,CAAY,UAACC,OAAD,EAAUC,MAAV,EAAqB;UAChCC,cAAc,SAAdA,WAAc;eAAMF,QAAQ,IAAR,CAAN;OAApB;;aACOxB,IAAP,CAAY,KAAZ,EAAmB0B,WAAnB;aACO1B,IAAP,CAAY,OAAZ,EAAqByB,MAArB;aACOzB,IAAP,CAAY,UAAZ,EAAwB,YAAM;eACrBC,cAAP,CAAsB,KAAtB,EAA6ByB,WAA7B;eACOzB,cAAP,CAAsB,OAAtB,EAA+BwB,MAA/B;gBACQJ,OAAOtB,IAAP,EAAR;OAHF;KAJK,CAAP;;;SAWKwB,QAAQC,OAAR,CAAgB1B,KAAhB,CAAP;;;AAGF,SAAS6B,gBAAT,CAA0BC,OAA1B,EAAmC;SAC1BA,QAAQxB,IAAR,CAAa,UAACyB,GAAD,EAAS;QACrBC,UAAU3B,QAAQ0B,GAAR,CAAhB;WACOC,YAAY,SAAZ,GAAwBH,iBAAiBE,GAAjB,CAAxB,GAAgDA,GAAvD;GAFK,CAAP;;;IAMIE;;;;;+BACQjC,KAAZ,EAAmBkC,QAAnB,EAA6BC,MAA7B,EAAqCC,KAArC,EAA4C;;;;;6FACpC,EAAN;QACIC,GAAJ;;QACMC,oBAAmBH,MAAnB,CAAN;;QACIG,cAAc,QAAd,IAA0BA,cAAc,QAA5C,EAAsD;YAC9CC,OAAOC,QAAP,CAAgBL,MAAhB,IAA0B,IAAIM,MAAJ,CAAWN,MAAX,CAA1B,GAA+CA,MAArD;;;WAEKO,MAAP,wDAAoB;eACTN,QAAQ,IAAIO,OAAJ,EAAR,GAAwB,IAAIC,OAAJ,EADf;kBAAA;aAGX,EAHW;wBAIAV,oBAAoBW,QAApB,IAAgCX,QAJhC;qBAKH1B,MAAMC,OAAN,CAAcyB,QAAd,KAA2BA,QALxB;cAAA;aAOX;KAPT;;UASKY,UAAL,CAAgB9C,KAAhB;;;;;;;2BAGK+C,KAAK/C,OAAO;UACXgD,eAAe,KAAKC,OAAL,CAAaC,GAAb,CAAiBlD,KAAjB,CAArB;;UACIgD,YAAJ,EAAkB;eACT;gBACCA;SADR;;;UAIEG,OAAO,KAAKA,IAAL,EAAX;UACIJ,QAAQK,SAAZ,EAAuBD,KAAKE,IAAL,CAAUN,GAAV;aAChBI,KAAKG,GAAL,CAAS;0BAAUf,OAAOgB,SAAP,CAAiBC,CAAjB,IAAsBA,CAAtB,GAA0BnC,YAAYmC,CAAZ,CAApC;OAAT,CAAP;WACKP,OAAL,CAAaQ,GAAb,CAAiBzD,KAAjB,EAAwBmD,KAAKO,MAAL,cAAkBP,KAAKQ,IAAL,CAAU,EAAV,CAAlB,IAAoC,GAA5D;aACO3D,KAAP;;;;+BAGSA,OAAO+C,KAAKa,OAAO;;;UACxBC,YAAY7D,KAAhB;;UACI,KAAK8D,gBAAT,EAA2B;oBACb,KAAKA,gBAAL,CAAsBf,OAAOa,KAA7B,EAAoCC,SAApC,EAA+C,IAA/C,CAAZ;OAH0B;;;UAMxBA,aAAaA,UAAUE,MAAV,YAA4BlB,QAA7C,EAAuD;oBACzCgB,UAAUE,MAAV,EAAZ;;;UAEEF,qBAAqBhB,QAArB,IAAiC,QAAO7C,KAAP,MAAiB,QAAtD,EAAgE;oBAClDoD,SAAZ;;;UAEEL,QAAQK,SAAR,IAAqB,KAAKY,aAA9B,EAA6C;YACvC,CAAC,KAAKA,aAAL,CAAmBC,QAAnB,CAA4BlB,GAA5B,CAAL,EAAuC;sBACzBK,SAAZ;;;;UAGAc,OAAO7D,QAAQwD,SAAR,CAAX;;UACIA,cAAcT,SAAd,IAA2Bc,SAAS,SAApC,IAAiDnB,GAArD,EAA0D;YACpD,KAAKV,GAAT,EAAc;eACP8B,KAAL,aAAgB,KAAK9B,GAAL,CAASI,MAAT,CAAgB,KAAK2B,KAArB,CAAhB,eAA+CvD,aAAakC,GAAb,CAA/C;SADF,MAEO;eACAoB,KAAL,aAAetD,aAAakC,GAAb,CAAf;;;;UAGAmB,SAAS,WAAb,EAA0B;YACpB,KAAK9B,KAAT,EAAgB;;sBAEF,KAAKiC,MAAL,CAAYtB,OAAOa,KAAnB,EAA0BC,SAA1B,CAAZ;iBACOxD,QAAQwD,SAAR,CAAP;SAHF,MAIO;;cAED,KAAKZ,OAAL,CAAaqB,GAAb,CAAiBT,SAAjB,CAAJ,EAAiC;kBACzBnD,OAAOgC,MAAP,CAAc,IAAI6B,KAAJ,CAAU,uCAAV,CAAd,EAAkE;kCAAA;mBAEjExB,OAAOa;aAFR,CAAN;;;eAKGX,OAAL,CAAauB,GAAb,CAAiBX,SAAjB;;;;UAIA,CAACd,GAAD,IAAQa,QAAQ,CAAC,CAAjB,IAAsB,KAAKQ,KAA3B,IAAoC,KAAK/B,GAA7C,EAAkD,KAAK8B,KAAL,aAAgB,KAAK9B,GAAL,CAASI,MAAT,CAAgB,KAAK2B,KAArB,CAAhB;UAE5CK,OAAO7D,cAAcsD,IAAd,CAAb;UACIO,IAAJ,EAAU,KAAKN,KAAL,CAAWM,IAAX;UAEJC,MAAM;gBAAA;oBAAA;kBAAA;eAIHb;OAJT;;UAOIK,SAAS,QAAb,EAAuB;aAChBE,KAAL,IAAc,CAAd;YACIO,MAAJ,GAAajE,OAAOkE,IAAP,CAAYf,SAAZ,CAAb;YACIgB,OAAJ,GAAc,CAACH,IAAIC,MAAJ,CAAWjB,MAA1B;OAHF,MAIO,IAAIQ,SAAS,OAAb,EAAsB;aACtBE,KAAL,IAAc,CAAd;YACIO,MAAJ,GAAanE,MAAMsE,IAAN,CAAWtE,MAAMqD,UAAUH,MAAhB,EAAwBkB,IAAxB,EAAX,CAAb;YACIC,OAAJ,GAAc,CAACH,IAAIC,MAAJ,CAAWjB,MAA1B;OAHK,MAIA,IAAIQ,KAAKa,UAAL,CAAgB,UAAhB,CAAJ,EAAiC;aACjCX,KAAL,IAAc,CAAd;;YACIP,UAAUzD,cAAV,CAAyB4E,KAA7B,EAAoC;eAC7BC,IAAL,CAAU,OAAV,EAAmB,IAAIV,KAAJ,CAAU,oFAAV,CAAnB,EAAoHV,SAApH,EAA+Hd,OAAOa,KAAtI;SADF,MAEO,IAAIC,UAAUzD,cAAV,CAAyB8E,OAA7B,EAAsC;oBACjCC,KAAV;eACKF,IAAL,CAAU,OAAV,EAAmB,IAAIV,KAAJ,CAAU,sFAAV,CAAnB,EAAsHV,SAAtH,EAAiId,OAAOa,KAAxI;;;YAEEwB,SAAJ,GAAgB,CAAhB;kBACUlF,IAAV,CAAe,KAAf,EAAsB,YAAM;cACtBmF,GAAJ,GAAU,IAAV;;iBACKC,MAAL;SAFF;kBAIUpF,IAAV,CAAe,OAAf,EAAwB,UAACqF,GAAD,EAAS;iBAC1BC,KAAL,GAAa,IAAb;;iBACKP,IAAL,CAAU,OAAV,EAAmBM,GAAnB;SAFF;YAIIE,KAAJ,GAAY,IAAZ;;;WAEGC,KAAL,CAAWC,OAAX,CAAmBjB,GAAnB;aACOA,GAAP;;;;oCAGckB,MAAM;UAElB1B,IAFkB,GAGhB0B,IAHgB,CAElB1B,IAFkB;UAId2B,WAAW3B,SAAS,QAAT,IAAqBA,SAAS,OAA9B,IAAyCA,KAAKa,UAAL,CAAgB,UAAhB,CAA1D;;UACIb,SAAS,WAAb,EAA0B;YACpB,CAAC,KAAK9B,KAAV,EAAiB;eACVa,OAAL,CAAa6C,MAAb,CAAoBF,KAAK5F,KAAzB;;;YAEE6F,QAAJ,EAAc;eACPzB,KAAL,IAAc,CAAd;;;;UAIEiB,MAAM1E,aAAauD,IAAb,CAAZ;UACI2B,YAAY,CAACD,KAAKf,OAAlB,IAA6B,KAAKxC,GAAtC,EAA2C,KAAK8B,KAAL,aAAgB,KAAK9B,GAAL,CAASI,MAAT,CAAgB,KAAK2B,KAArB,CAAhB;UACvCiB,GAAJ,EAAS,KAAKlB,KAAL,CAAWkB,GAAX;;UACLO,KAAKG,oBAAT,EAA+B;aACxB5B,KAAL,CAAW,GAAX;;;WAEGuB,KAAL,CAAWM,MAAX,CAAkB,KAAKN,KAAL,CAAWO,OAAX,CAAmBL,IAAnB,CAAlB,EAA4C,CAA5C;;;;0BAGIM,MAAM;WACLC,UAAL,GAAkB,IAAlB;WACK9C,IAAL,CAAU6C,IAAV;;;;0CAGoBE,SAAS5E,MAAM;;;UAC/B4E,QAAQf,GAAZ,EAAiB;aACVgB,eAAL,CAAqBD,OAArB;eACOhD,SAAP;;;aAEK9B,eAAe8E,QAAQpG,KAAvB,EAA8BwB,IAA9B,EACJlB,IADI,CACC,UAACN,KAAD,EAAW;YACXA,UAAU,IAAd,EAAoB;cACd,CAACoG,QAAQX,KAAb,EAAoB;mBACbtB,KAAL,CAAW,GAAX;;;;;kBAGMsB,KAAR,GAAgB,KAAhB;;iBACK3C,UAAL,CAAgB9C,KAAhB,EAAuBoD,SAAvB,EAAkCgD,QAAQhB,SAA1C;;kBACQA,SAAR,IAAqB,CAArB;;;OATC,CAAP;;;;kCAeYgB,SAAS;UACjB,CAACA,QAAQzB,MAAR,CAAejB,MAApB,EAA4B;aACrB2C,eAAL,CAAqBD,OAArB;;;;UAGIrD,MAAMqD,QAAQzB,MAAR,CAAe2B,KAAf,EAAZ;UACMtG,QAAQoG,QAAQpG,KAAR,CAAc+C,GAAd,CAAd;WAEKD,UAAL,CAAgB9C,KAAhB,EAAuBoG,QAAQlC,IAAR,KAAiB,QAAjB,IAA6BnB,GAApD,EAAyDqD,QAAQlC,IAAR,KAAiB,OAAjB,IAA4BnB,GAArF,EAA0FgD,oBAA1F,GAAiH,CAAC,CAACK,QAAQzB,MAAR,CAAejB,MAAlI;;;;iCAGW0C,SAAS;aACb,KAAKG,aAAL,CAAmBH,OAAnB,CAAP;;;;qCAGeA,SAAS;UACpBA,QAAQpG,KAAR,KAAkBoD,SAAtB,EAAiC;YACzBc,eAAckC,QAAQpG,KAAtB,CAAN;;YACIA,KAAJ;;gBACQkE,IAAR;eACK,QAAL;oBACU7C,YAAY+E,QAAQpG,KAApB,CAAR;;;eAEG,QAAL;oBACUuC,OAAOC,QAAP,CAAgB4D,QAAQpG,KAAxB,IAAiCwG,OAAOJ,QAAQpG,KAAf,CAAjC,GAAyD,MAAjE;;;eAEG,SAAL;eACK,MAAL;oBACUwG,OAAOJ,QAAQpG,KAAf,CAAR;;;eAEG,QAAL;gBACM,CAACoG,QAAQpG,KAAb,EAAoB;sBACV,MAAR;;;;;;;;;kBAOIU,OAAOgC,MAAP,CAAc,IAAI6B,KAAJ,0BAA2BL,IAA3B,+BAAd,EAA0E;qBACvEkC,QAAQpG;aADX,CAAN;;;aAIGmE,KAAL,CAAWnE,KAAX;OA3BF,MA4BO,IAAI,KAAK0F,KAAL,CAAW,CAAX,MAAkB,KAAKA,KAAL,CAAW,CAAX,EAAcxB,IAAd,KAAuB,OAAvB,IAAkC,KAAKwB,KAAL,CAAW,CAAX,EAAcxB,IAAd,KAAuB,gBAA3E,CAAJ,EAAkG;aAClGC,KAAL,CAAW,MAAX;OADK,MAEA;;gBAEG4B,oBAAR,GAA+B,KAA/B;;;WAEGM,eAAL,CAAqBD,OAArB;;;;0CAGoBA,SAAS5E,MAAM;;;UAC/B4E,QAAQf,GAAZ,EAAiB;aACVgB,eAAL,CAAqBD,OAArB;eACOhD,SAAP;;;aAEK9B,eAAe8E,QAAQpG,KAAvB,EAA8BwB,IAA9B,EACJlB,IADI,CACC,UAACN,KAAD,EAAW;YACXA,KAAJ,EAAW,OAAKmE,KAAL,CAAWtD,aAAab,MAAMmB,QAAN,EAAb,CAAX;OAFR,CAAP;;;;mCAMaiF,SAAS;;;aACfvE,iBAAiBuE,QAAQpG,KAAzB,EAAgCM,IAAhC,CAAqC,UAACN,KAAD,EAAW;YAEnD+F,oBAFmD,GAGjDK,OAHiD,CAEnDL,oBAFmD;;;gBAK7CA,oBAAR,GAA+B,KAA/B;;eACKM,eAAL,CAAqBD,OAArB;;eACKtD,UAAL,CAAgB9C,KAAhB,EAAuBoG,QAAQrD,GAA/B,EAAoCqD,QAAQxC,KAA5C,EACGmC,oBADH,GAC0BA,oBAD1B;OAPK,CAAP;;;;wCAYkBvE,MAAM;;;UAClB4E,UAAU,KAAKV,KAAL,CAAW,CAAX,CAAhB;UACI,CAACU,OAAD,IAAY,KAAKZ,KAArB,EAA4B,OAAO/D,QAAQC,OAAR,EAAP;UACxB+E,GAAJ;;UACI;cACI,sBAAeL,QAAQlC,IAAvB,GAA+BkC,OAA/B,EAAwC5E,IAAxC,CAAN;OADF,CAEE,OAAO+D,GAAP,EAAY;eACL9D,QAAQE,MAAR,CAAe4D,GAAf,CAAP;;;aAEK9D,QAAQC,OAAR,CAAgB+E,GAAhB,EACJnG,IADI,CACC,YAAM;YACN,OAAKoF,KAAL,CAAWhC,MAAX,KAAsB,CAA1B,EAA6B;iBACtB2B,GAAL,GAAW,IAAX;;iBACKlB,KAAL,CAAW,IAAX;;OAJC,CAAP;;;;2BASK3C,MAAM;;;UACP,KAAKkF,SAAL,IAAkB,KAAKlB,KAA3B,EAAkC;aAC3BmB,QAAL,GAAgB,IAAhB;eACOvD,SAAP;;;WAEGsD,SAAL,GAAiB,IAAjB,CALW;;WAQNC,QAAL,GAAgB,KAAhB;aACO,KAAKC,mBAAL,CAAyBpF,IAAzB,EACJlB,IADI,CACC,YAAM;YACJuG,YAAY,CAAC,OAAKxB,GAAN,IAAa,CAAC,OAAKG,KAAnB,KAA6B,OAAKmB,QAAL,IAAiB,CAAC,OAAKR,UAApD,CAAlB;;YACIU,SAAJ,EAAe;uBACA,YAAM;mBACZH,SAAL,GAAiB,KAAjB;;mBACKpB,MAAL;WAFF;SADF,MAKO;iBACAoB,SAAL,GAAiB,KAAjB;;OATC,EAYJI,KAZI,CAYE,UAACvB,GAAD,EAAS;eACTC,KAAL,GAAa,IAAb;;eACKP,IAAL,CAAU,OAAV,EAAmBM,GAAnB;OAdG,CAAP;;;;0BAkBI/D,MAAM;WACL2E,UAAL,GAAkB,KAAlB;;WACKb,MAAL,CAAY9D,IAAZ;;;;2BAGK;aACE,KAAKkE,KAAL,CAAWpC,GAAX,CAAe;YACpBP,GADoB,QACpBA,GADoB;YAEpBa,KAFoB,QAEpBA,KAFoB;eAGhBb,OAAOa,KAHS;OAAf,EAGamD,MAHb,CAGoB;eAAKvD,KAAKA,IAAI,CAAC,CAAf;OAHpB,EAGsCwD,OAHtC,EAAP;;;;;EAvS8BC;;;;"} |
| import 'core-js/modules/es6.array.filter'; | ||
| import _setImmediate from '@babel/runtime/core-js/set-immediate'; | ||
| import 'core-js/modules/es6.array.index-of'; | ||
| import 'core-js/modules/es6.string.starts-with'; | ||
| import 'core-js/modules/web.dom.iterable'; | ||
| import 'core-js/modules/es6.array.iterator'; | ||
| import _Array$from from '@babel/runtime/core-js/array/from'; | ||
| import _Object$keys from '@babel/runtime/core-js/object/keys'; | ||
| import 'core-js/modules/es7.array.includes'; | ||
| import 'core-js/modules/es6.string.includes'; | ||
| import 'core-js/modules/es6.date.to-json'; | ||
| import _Number$isInteger from '@babel/runtime/core-js/number/is-integer'; | ||
| import 'core-js/modules/es6.array.map'; | ||
| import _WeakSet from '@babel/runtime/core-js/weak-set'; | ||
| import _WeakMap from '@babel/runtime/core-js/weak-map'; | ||
| import _Object$assign from '@babel/runtime/core-js/object/assign'; | ||
| import 'core-js/modules/es6.string.repeat'; | ||
| import _Number$isFinite from '@babel/runtime/core-js/number/is-finite'; | ||
| import _Promise from '@babel/runtime/core-js/promise'; | ||
| import 'core-js/modules/es6.regexp.to-string'; | ||
| import 'core-js/modules/es6.date.to-string'; | ||
| import 'core-js/modules/es7.string.pad-start'; | ||
| import 'core-js/modules/es6.regexp.replace'; | ||
| import 'core-js/modules/es6.array.is-array'; | ||
| import { Readable } from 'stream'; | ||
| 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 _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 _inherits(subClass, superClass) { | ||
| if (typeof superClass !== "function" && superClass !== null) { | ||
| throw new TypeError("Super expression must either be null or a function"); | ||
| } | ||
| subClass.prototype = Object.create(superClass && superClass.prototype, { | ||
| constructor: { | ||
| value: subClass, | ||
| writable: true, | ||
| configurable: true | ||
| } | ||
| }); | ||
| if (superClass) _setPrototypeOf(subClass, superClass); | ||
| } | ||
| function _getPrototypeOf(o) { | ||
| _getPrototypeOf = Object.setPrototypeOf ? Object.getPrototypeOf : function _getPrototypeOf(o) { | ||
| return o.__proto__ || Object.getPrototypeOf(o); | ||
| }; | ||
| return _getPrototypeOf(o); | ||
| } | ||
| function _setPrototypeOf(o, p) { | ||
| _setPrototypeOf = Object.setPrototypeOf || function _setPrototypeOf(o, p) { | ||
| o.__proto__ = p; | ||
| return o; | ||
| }; | ||
| return _setPrototypeOf(o, p); | ||
| } | ||
| function _assertThisInitialized(self) { | ||
| if (self === void 0) { | ||
| throw new ReferenceError("this hasn't been initialised - super() hasn't been called"); | ||
| } | ||
| return self; | ||
| } | ||
| function _possibleConstructorReturn(self, call) { | ||
| if (call && (typeof call === "object" || typeof call === "function")) { | ||
| return call; | ||
| } | ||
| return _assertThisInitialized(self); | ||
| } | ||
| var rxEscapable = /[\\"\u0000-\u001f\u007f-\u009f\u00ad\u0600-\u0604\u070f\u17b4\u17b5\u200c-\u200f\u2028-\u202f\u2060-\u206f\ufeff\ufff0-\uffff]/g; // table of character substitutions | ||
| var meta = { | ||
| '\b': '\\b', | ||
| '\t': '\\t', | ||
| '\n': '\\n', | ||
| '\f': '\\f', | ||
| '\r': '\\r', | ||
| '"': '\\"', | ||
| '\\': '\\\\' | ||
| }; | ||
| function isReadableStream(value) { | ||
| return typeof value.read === 'function' && typeof value.once === 'function' && typeof value.removeListener === 'function' && _typeof(value._readableState) === 'object'; | ||
| } | ||
| function getType(value) { | ||
| if (!value) return 'Primitive'; | ||
| if (typeof value.then === 'function') return 'Promise'; | ||
| if (isReadableStream(value)) return "Readable".concat(value._readableState.objectMode ? 'Object' : 'String'); | ||
| if (Array.isArray(value)) return 'Array'; | ||
| if (_typeof(value) === 'object' || value instanceof Object) return 'Object'; | ||
| return 'Primitive'; | ||
| } | ||
| var stackItemEnd = { | ||
| Array: ']', | ||
| Object: '}', | ||
| ReadableString: '"', | ||
| ReadableObject: ']' | ||
| }; | ||
| var stackItemOpen = { | ||
| Array: '[', | ||
| Object: '{', | ||
| ReadableString: '"', | ||
| ReadableObject: '[' | ||
| }; | ||
| function escapeString(string) { | ||
| // Modified code, original code by Douglas Crockford | ||
| // Original: https://github.com/douglascrockford/JSON-js/blob/master/json2.js | ||
| // If the string contains no control characters, no quote characters, and no | ||
| // backslash characters, then we can safely slap some quotes around it. | ||
| // Otherwise we must also replace the offending characters with safe escape | ||
| // sequences. | ||
| return string.replace(rxEscapable, function (a) { | ||
| var c = meta[a]; | ||
| return typeof c === 'string' ? c : "\\u".concat(a.charCodeAt(0).toString(16).padStart(4, '0')); | ||
| }); | ||
| } | ||
| function quoteString(string) { | ||
| return "\"".concat(escapeString(string), "\""); | ||
| } | ||
| function readAsPromised(stream, size) { | ||
| var value = stream.read(size); | ||
| if (value === null) { | ||
| return new _Promise(function (resolve, reject) { | ||
| var endListener = function endListener() { | ||
| return resolve(null); | ||
| }; | ||
| stream.once('end', endListener); | ||
| stream.once('error', reject); | ||
| stream.once('readable', function () { | ||
| stream.removeListener('end', endListener); | ||
| stream.removeListener('error', reject); | ||
| resolve(stream.read()); | ||
| }); | ||
| }); | ||
| } | ||
| return _Promise.resolve(value); | ||
| } | ||
| function recursiveResolve(promise) { | ||
| return promise.then(function (res) { | ||
| var resType = getType(res); | ||
| return resType === 'Promise' ? recursiveResolve(res) : res; | ||
| }); | ||
| } | ||
| var JsonStreamStringify = | ||
| /*#__PURE__*/ | ||
| function (_Readable) { | ||
| _inherits(JsonStreamStringify, _Readable); | ||
| function JsonStreamStringify(value, replacer, spaces, cycle) { | ||
| var _this; | ||
| _classCallCheck(this, JsonStreamStringify); | ||
| _this = _possibleConstructorReturn(this, _getPrototypeOf(JsonStreamStringify).call(this, {})); | ||
| var gap; | ||
| var spaceType = _typeof(spaces); | ||
| if (spaceType === 'string' || spaceType === 'number') { | ||
| gap = _Number$isFinite(spaces) ? ' '.repeat(spaces) : spaces; | ||
| } | ||
| _Object$assign(_assertThisInitialized(_assertThisInitialized(_this)), { | ||
| visited: cycle ? new _WeakMap() : new _WeakSet(), | ||
| cycle: cycle, | ||
| stack: [], | ||
| replacerFunction: replacer instanceof Function && replacer, | ||
| replacerArray: Array.isArray(replacer) && replacer, | ||
| gap: gap, | ||
| depth: 0 | ||
| }); | ||
| _this.addToStack(value); | ||
| return _this; | ||
| } | ||
| _createClass(JsonStreamStringify, [{ | ||
| key: "cycler", | ||
| value: function cycler(key, value) { | ||
| var existingPath = this.visited.get(value); | ||
| if (existingPath) { | ||
| return { | ||
| $ref: existingPath | ||
| }; | ||
| } | ||
| var path = this.path(); | ||
| if (key !== undefined) path.push(key); | ||
| path = path.map(function (v) { | ||
| return "[".concat(_Number$isInteger(v) ? v : quoteString(v), "]"); | ||
| }); | ||
| this.visited.set(value, path.length ? "$".concat(path.join('')) : '$'); | ||
| return value; | ||
| } | ||
| }, { | ||
| key: "addToStack", | ||
| value: function addToStack(value, key, index) { | ||
| var _this2 = this; | ||
| var realValue = value; | ||
| if (this.replacerFunction) { | ||
| realValue = this.replacerFunction(key || index, realValue, this); | ||
| } // ORDER? | ||
| if (realValue && realValue.toJSON instanceof Function) { | ||
| realValue = realValue.toJSON(); | ||
| } | ||
| if (realValue instanceof Function || _typeof(value) === 'symbol') { | ||
| realValue = undefined; | ||
| } | ||
| if (key !== undefined && this.replacerArray) { | ||
| if (!this.replacerArray.includes(key)) { | ||
| realValue = undefined; | ||
| } | ||
| } | ||
| var type = getType(realValue); | ||
| if (realValue !== undefined && type !== 'Promise' && key) { | ||
| if (this.gap) { | ||
| this._push("\n".concat(this.gap.repeat(this.depth), "\"").concat(escapeString(key), "\": ")); | ||
| } else { | ||
| this._push("\"".concat(escapeString(key), "\":")); | ||
| } | ||
| } | ||
| if (type !== 'Primitive') { | ||
| if (this.cycle) { | ||
| // run cycler | ||
| realValue = this.cycler(key || index, realValue); | ||
| type = getType(realValue); | ||
| } else { | ||
| // check for circular structure | ||
| if (this.visited.has(realValue)) { | ||
| throw _Object$assign(new Error('Converting circular structure to JSON'), { | ||
| realValue: realValue, | ||
| key: key || index | ||
| }); | ||
| } | ||
| this.visited.add(realValue); | ||
| } | ||
| } | ||
| if (!key && index > -1 && this.depth && this.gap) this._push("\n".concat(this.gap.repeat(this.depth))); | ||
| var open = stackItemOpen[type]; | ||
| if (open) this._push(open); | ||
| var obj = { | ||
| key: key, | ||
| index: index, | ||
| type: type, | ||
| value: realValue | ||
| }; | ||
| if (type === 'Object') { | ||
| this.depth += 1; | ||
| obj.unread = _Object$keys(realValue); | ||
| obj.isEmpty = !obj.unread.length; | ||
| } else if (type === 'Array') { | ||
| this.depth += 1; | ||
| obj.unread = _Array$from(Array(realValue.length).keys()); | ||
| obj.isEmpty = !obj.unread.length; | ||
| } else if (type.startsWith('Readable')) { | ||
| this.depth += 1; | ||
| if (realValue._readableState.ended) { | ||
| this.emit('error', new Error('Readable Stream has ended before it was serialized. All stream data have been lost'), realValue, key || index); | ||
| } else if (realValue._readableState.flowing) { | ||
| realValue.pause(); | ||
| this.emit('error', new Error('Readable Stream is in flowing mode, data may have been lost. Trying to pause stream.'), realValue, key || index); | ||
| } | ||
| obj.readCount = 0; | ||
| realValue.once('end', function () { | ||
| obj.end = true; | ||
| _this2.__read(); | ||
| }); | ||
| realValue.once('error', function (err) { | ||
| _this2.error = true; | ||
| _this2.emit('error', err); | ||
| }); | ||
| obj.first = true; | ||
| } | ||
| this.stack.unshift(obj); | ||
| return obj; | ||
| } | ||
| }, { | ||
| key: "removeFromStack", | ||
| value: function removeFromStack(item) { | ||
| var type = item.type; | ||
| var isObject = type === 'Object' || type === 'Array' || type.startsWith('Readable'); | ||
| if (type !== 'Primitive') { | ||
| if (!this.cycle) { | ||
| this.visited.delete(item.value); | ||
| } | ||
| if (isObject) { | ||
| this.depth -= 1; | ||
| } | ||
| } | ||
| var end = stackItemEnd[type]; | ||
| if (isObject && !item.isEmpty && this.gap) this._push("\n".concat(this.gap.repeat(this.depth))); | ||
| if (end) this._push(end); | ||
| if (item.addSeparatorAfterEnd) { | ||
| this._push(','); | ||
| } | ||
| this.stack.splice(this.stack.indexOf(item), 1); | ||
| } | ||
| }, { | ||
| key: "_push", | ||
| value: function _push(data) { | ||
| this.pushCalled = true; | ||
| this.push(data); | ||
| } | ||
| }, { | ||
| key: "processReadableObject", | ||
| value: function processReadableObject(current, size) { | ||
| var _this3 = this; | ||
| if (current.end) { | ||
| this.removeFromStack(current); | ||
| return undefined; | ||
| } | ||
| return readAsPromised(current.value, size).then(function (value) { | ||
| if (value !== null) { | ||
| if (!current.first) { | ||
| _this3._push(','); | ||
| } | ||
| /* eslint-disable no-param-reassign */ | ||
| current.first = false; | ||
| _this3.addToStack(value, undefined, current.readCount); | ||
| current.readCount += 1; | ||
| /* eslint-enable no-param-reassign */ | ||
| } | ||
| }); | ||
| } | ||
| }, { | ||
| key: "processObject", | ||
| value: function processObject(current) { | ||
| if (!current.unread.length) { | ||
| this.removeFromStack(current); | ||
| return; | ||
| } | ||
| var key = current.unread.shift(); | ||
| var value = current.value[key]; | ||
| this.addToStack(value, current.type === 'Object' && key, current.type === 'Array' && key).addSeparatorAfterEnd = !!current.unread.length; | ||
| } | ||
| }, { | ||
| key: "processArray", | ||
| value: function processArray(current) { | ||
| return this.processObject(current); | ||
| } | ||
| }, { | ||
| key: "processPrimitive", | ||
| value: function processPrimitive(current) { | ||
| if (current.value !== undefined) { | ||
| var type = _typeof(current.value); | ||
| var value; | ||
| switch (type) { | ||
| case 'string': | ||
| value = quoteString(current.value); | ||
| break; | ||
| case 'number': | ||
| value = _Number$isFinite(current.value) ? String(current.value) : 'null'; | ||
| break; | ||
| case 'boolean': | ||
| case 'null': | ||
| value = String(current.value); | ||
| break; | ||
| case 'object': | ||
| if (!current.value) { | ||
| value = 'null'; | ||
| break; | ||
| } | ||
| /* eslint-disable-next-line no-fallthrough */ | ||
| default: | ||
| // This should never happen, I can't imagine a situation where this executes. | ||
| // If you find a way, please open a ticket or PR | ||
| throw _Object$assign(new Error("Unknown type \"".concat(type, "\". Please file an issue!")), { | ||
| value: current.value | ||
| }); | ||
| } | ||
| this._push(value); | ||
| } else if (this.stack[1] && (this.stack[1].type === 'Array' || this.stack[1].type === 'ReadableObject')) { | ||
| this._push('null'); | ||
| } else { | ||
| /* eslint-disable-next-line no-param-reassign */ | ||
| current.addSeparatorAfterEnd = false; | ||
| } | ||
| this.removeFromStack(current); | ||
| } | ||
| }, { | ||
| key: "processReadableString", | ||
| value: function processReadableString(current, size) { | ||
| var _this4 = this; | ||
| if (current.end) { | ||
| this.removeFromStack(current); | ||
| return undefined; | ||
| } | ||
| return readAsPromised(current.value, size).then(function (value) { | ||
| if (value) _this4._push(escapeString(value.toString())); | ||
| }); | ||
| } | ||
| }, { | ||
| key: "processPromise", | ||
| value: function processPromise(current) { | ||
| var _this5 = this; | ||
| return recursiveResolve(current.value).then(function (value) { | ||
| var addSeparatorAfterEnd = current.addSeparatorAfterEnd; | ||
| /* eslint-disable-next-line no-param-reassign */ | ||
| current.addSeparatorAfterEnd = false; | ||
| _this5.removeFromStack(current); | ||
| _this5.addToStack(value, current.key, current.index).addSeparatorAfterEnd = addSeparatorAfterEnd; | ||
| }); | ||
| } | ||
| }, { | ||
| key: "processStackTopItem", | ||
| value: function processStackTopItem(size) { | ||
| var _this6 = this; | ||
| var current = this.stack[0]; | ||
| if (!current || this.error) return _Promise.resolve(); | ||
| var out; | ||
| try { | ||
| out = this["process".concat(current.type)](current, size); | ||
| } catch (err) { | ||
| return _Promise.reject(err); | ||
| } | ||
| return _Promise.resolve(out).then(function () { | ||
| if (_this6.stack.length === 0) { | ||
| _this6.end = true; | ||
| _this6._push(null); | ||
| } | ||
| }); | ||
| } | ||
| }, { | ||
| key: "__read", | ||
| value: function __read(size) { | ||
| var _this7 = this; | ||
| if (this.isRunning || this.error) { | ||
| this.readMore = true; | ||
| return undefined; | ||
| } | ||
| this.isRunning = true; // we must continue to read while push has not been called | ||
| this.readMore = false; | ||
| return this.processStackTopItem(size).then(function () { | ||
| var readAgain = !_this7.end && !_this7.error && (_this7.readMore || !_this7.pushCalled); | ||
| if (readAgain) { | ||
| _setImmediate(function () { | ||
| _this7.isRunning = false; | ||
| _this7.__read(); | ||
| }); | ||
| } else { | ||
| _this7.isRunning = false; | ||
| } | ||
| }).catch(function (err) { | ||
| _this7.error = true; | ||
| _this7.emit('error', err); | ||
| }); | ||
| } | ||
| }, { | ||
| key: "_read", | ||
| value: function _read(size) { | ||
| this.pushCalled = false; | ||
| this.__read(size); | ||
| } | ||
| }, { | ||
| key: "path", | ||
| value: function path() { | ||
| return this.stack.map(function (_ref) { | ||
| var key = _ref.key, | ||
| index = _ref.index; | ||
| return key || index; | ||
| }).filter(function (v) { | ||
| return v || v > -1; | ||
| }).reverse(); | ||
| } | ||
| }]); | ||
| return JsonStreamStringify; | ||
| }(Readable); | ||
| export default JsonStreamStringify; | ||
| //# sourceMappingURL=module.polyfill.js.map |
| {"version":3,"file":"module.polyfill.js","sources":["../src/JsonStreamStringify.js"],"sourcesContent":["import { Readable } from 'stream';\n\nconst rxEscapable = /[\\\\\"\\u0000-\\u001f\\u007f-\\u009f\\u00ad\\u0600-\\u0604\\u070f\\u17b4\\u17b5\\u200c-\\u200f\\u2028-\\u202f\\u2060-\\u206f\\ufeff\\ufff0-\\uffff]/g;\n\n// table of character substitutions\nconst meta = {\n '\\b': '\\\\b',\n '\\t': '\\\\t',\n '\\n': '\\\\n',\n '\\f': '\\\\f',\n '\\r': '\\\\r',\n '\"': '\\\\\"',\n '\\\\': '\\\\\\\\',\n};\n\nfunction isReadableStream(value) {\n return typeof value.read === 'function'\n && typeof value.once === 'function'\n && typeof value.removeListener === 'function'\n && typeof value._readableState === 'object';\n}\n\nfunction getType(value) {\n if (!value) return 'Primitive';\n if (typeof value.then === 'function') return 'Promise';\n if (isReadableStream(value)) return `Readable${value._readableState.objectMode ? 'Object' : 'String'}`;\n if (Array.isArray(value)) return 'Array';\n if (typeof value === 'object' || value instanceof Object) return 'Object';\n return 'Primitive';\n}\n\nconst stackItemEnd = {\n Array: ']',\n Object: '}',\n ReadableString: '\"',\n ReadableObject: ']',\n};\n\nconst stackItemOpen = {\n Array: '[',\n Object: '{',\n ReadableString: '\"',\n ReadableObject: '[',\n};\n\nfunction escapeString(string) {\n // Modified code, original code by Douglas Crockford\n // Original: https://github.com/douglascrockford/JSON-js/blob/master/json2.js\n\n // If the string contains no control characters, no quote characters, and no\n // backslash characters, then we can safely slap some quotes around it.\n // Otherwise we must also replace the offending characters with safe escape\n // sequences.\n\n return string.replace(rxEscapable, (a) => {\n const c = meta[a];\n return typeof c === 'string' ? c : `\\\\u${a.charCodeAt(0).toString(16).padStart(4, '0')}`;\n });\n}\n\nfunction quoteString(string) {\n return `\"${escapeString(string)}\"`;\n}\n\nfunction readAsPromised(stream, size) {\n const value = stream.read(size);\n if (value === null) {\n return new Promise((resolve, reject) => {\n const endListener = () => resolve(null);\n stream.once('end', endListener);\n stream.once('error', reject);\n stream.once('readable', () => {\n stream.removeListener('end', endListener);\n stream.removeListener('error', reject);\n resolve(stream.read());\n });\n });\n }\n return Promise.resolve(value);\n}\n\nfunction recursiveResolve(promise) {\n return promise.then((res) => {\n const resType = getType(res);\n return resType === 'Promise' ? recursiveResolve(res) : res;\n });\n}\n\nclass JsonStreamStringify extends Readable {\n constructor(value, replacer, spaces, cycle) {\n super({});\n let gap;\n const spaceType = typeof spaces;\n if (spaceType === 'string' || spaceType === 'number') {\n gap = Number.isFinite(spaces) ? ' '.repeat(spaces) : spaces;\n }\n Object.assign(this, {\n visited: cycle ? new WeakMap() : new WeakSet(),\n cycle,\n stack: [],\n replacerFunction: replacer instanceof Function && replacer,\n replacerArray: Array.isArray(replacer) && replacer,\n gap,\n depth: 0,\n });\n this.addToStack(value);\n }\n\n cycler(key, value) {\n const existingPath = this.visited.get(value);\n if (existingPath) {\n return {\n $ref: existingPath,\n };\n }\n let path = this.path();\n if (key !== undefined) path.push(key);\n path = path.map(v => `[${(Number.isInteger(v) ? v : quoteString(v))}]`);\n this.visited.set(value, path.length ? `$${path.join('')}` : '$');\n return value;\n }\n\n addToStack(value, key, index) {\n let realValue = value;\n if (this.replacerFunction) {\n realValue = this.replacerFunction(key || index, realValue, this);\n }\n // ORDER?\n if (realValue && realValue.toJSON instanceof Function) {\n realValue = realValue.toJSON();\n }\n if (realValue instanceof Function || typeof value === 'symbol') {\n realValue = undefined;\n }\n if (key !== undefined && this.replacerArray) {\n if (!this.replacerArray.includes(key)) {\n realValue = undefined;\n }\n }\n let type = getType(realValue);\n if (realValue !== undefined && type !== 'Promise' && key) {\n if (this.gap) {\n this._push(`\\n${this.gap.repeat(this.depth)}\"${escapeString(key)}\": `);\n } else {\n this._push(`\"${escapeString(key)}\":`);\n }\n }\n if (type !== 'Primitive') {\n if (this.cycle) {\n // run cycler\n realValue = this.cycler(key || index, realValue);\n type = getType(realValue);\n } else {\n // check for circular structure\n if (this.visited.has(realValue)) {\n throw Object.assign(new Error('Converting circular structure to JSON'), {\n realValue,\n key: key || index,\n });\n }\n this.visited.add(realValue);\n }\n }\n\n if (!key && index > -1 && this.depth && this.gap) this._push(`\\n${this.gap.repeat(this.depth)}`);\n\n const open = stackItemOpen[type];\n if (open) this._push(open);\n\n const obj = {\n key,\n index,\n type,\n value: realValue,\n };\n\n if (type === 'Object') {\n this.depth += 1;\n obj.unread = Object.keys(realValue);\n obj.isEmpty = !obj.unread.length;\n } else if (type === 'Array') {\n this.depth += 1;\n obj.unread = Array.from(Array(realValue.length).keys());\n obj.isEmpty = !obj.unread.length;\n } else if (type.startsWith('Readable')) {\n this.depth += 1;\n if (realValue._readableState.ended) {\n this.emit('error', new Error('Readable Stream has ended before it was serialized. All stream data have been lost'), realValue, key || index);\n } else if (realValue._readableState.flowing) {\n realValue.pause();\n this.emit('error', new Error('Readable Stream is in flowing mode, data may have been lost. Trying to pause stream.'), realValue, key || index);\n }\n obj.readCount = 0;\n realValue.once('end', () => {\n obj.end = true;\n this.__read();\n });\n realValue.once('error', (err) => {\n this.error = true;\n this.emit('error', err);\n });\n obj.first = true;\n }\n this.stack.unshift(obj);\n return obj;\n }\n\n removeFromStack(item) {\n const {\n type,\n } = item;\n const isObject = type === 'Object' || type === 'Array' || type.startsWith('Readable');\n if (type !== 'Primitive') {\n if (!this.cycle) {\n this.visited.delete(item.value);\n }\n if (isObject) {\n this.depth -= 1;\n }\n }\n\n const end = stackItemEnd[type];\n if (isObject && !item.isEmpty && this.gap) this._push(`\\n${this.gap.repeat(this.depth)}`);\n if (end) this._push(end);\n if (item.addSeparatorAfterEnd) {\n this._push(',');\n }\n this.stack.splice(this.stack.indexOf(item), 1);\n }\n\n _push(data) {\n this.pushCalled = true;\n this.push(data);\n }\n\n processReadableObject(current, size) {\n if (current.end) {\n this.removeFromStack(current);\n return undefined;\n }\n return readAsPromised(current.value, size)\n .then((value) => {\n if (value !== null) {\n if (!current.first) {\n this._push(',');\n }\n /* eslint-disable no-param-reassign */\n current.first = false;\n this.addToStack(value, undefined, current.readCount);\n current.readCount += 1;\n /* eslint-enable no-param-reassign */\n }\n });\n }\n\n processObject(current) {\n if (!current.unread.length) {\n this.removeFromStack(current);\n return;\n }\n const key = current.unread.shift();\n const value = current.value[key];\n\n this.addToStack(value, current.type === 'Object' && key, current.type === 'Array' && key).addSeparatorAfterEnd = !!current.unread.length;\n }\n\n processArray(current) {\n return this.processObject(current);\n }\n\n processPrimitive(current) {\n if (current.value !== undefined) {\n const type = typeof current.value;\n let value;\n switch (type) {\n case 'string':\n value = quoteString(current.value);\n break;\n case 'number':\n value = Number.isFinite(current.value) ? String(current.value) : 'null';\n break;\n case 'boolean':\n case 'null':\n value = String(current.value);\n break;\n case 'object':\n if (!current.value) {\n value = 'null';\n break;\n }\n /* eslint-disable-next-line no-fallthrough */\n default:\n // This should never happen, I can't imagine a situation where this executes.\n // If you find a way, please open a ticket or PR\n throw Object.assign(new Error(`Unknown type \"${type}\". Please file an issue!`), {\n value: current.value,\n });\n }\n this._push(value);\n } else if (this.stack[1] && (this.stack[1].type === 'Array' || this.stack[1].type === 'ReadableObject')) {\n this._push('null');\n } else {\n /* eslint-disable-next-line no-param-reassign */\n current.addSeparatorAfterEnd = false;\n }\n this.removeFromStack(current);\n }\n\n processReadableString(current, size) {\n if (current.end) {\n this.removeFromStack(current);\n return undefined;\n }\n return readAsPromised(current.value, size)\n .then((value) => {\n if (value) this._push(escapeString(value.toString()));\n });\n }\n\n processPromise(current) {\n return recursiveResolve(current.value).then((value) => {\n const {\n addSeparatorAfterEnd,\n } = current;\n /* eslint-disable-next-line no-param-reassign */\n current.addSeparatorAfterEnd = false;\n this.removeFromStack(current);\n this.addToStack(value, current.key, current.index)\n .addSeparatorAfterEnd = addSeparatorAfterEnd;\n });\n }\n\n processStackTopItem(size) {\n const current = this.stack[0];\n if (!current || this.error) return Promise.resolve();\n let out;\n try {\n out = this[`process${current.type}`](current, size);\n } catch (err) {\n return Promise.reject(err);\n }\n return Promise.resolve(out)\n .then(() => {\n if (this.stack.length === 0) {\n this.end = true;\n this._push(null);\n }\n });\n }\n\n __read(size) {\n if (this.isRunning || this.error) {\n this.readMore = true;\n return undefined;\n }\n this.isRunning = true;\n\n // we must continue to read while push has not been called\n this.readMore = false;\n return this.processStackTopItem(size)\n .then(() => {\n const readAgain = !this.end && !this.error && (this.readMore || !this.pushCalled);\n if (readAgain) {\n setImmediate(() => {\n this.isRunning = false;\n this.__read();\n });\n } else {\n this.isRunning = false;\n }\n })\n .catch((err) => {\n this.error = true;\n this.emit('error', err);\n });\n }\n\n _read(size) {\n this.pushCalled = false;\n this.__read(size);\n }\n\n path() {\n return this.stack.map(({\n key,\n index,\n }) => key || index).filter(v => v || v > -1).reverse();\n }\n}\n\nexport default JsonStreamStringify;\n"],"names":["rxEscapable","meta","isReadableStream","value","read","once","removeListener","_readableState","getType","then","objectMode","Array","isArray","Object","stackItemEnd","stackItemOpen","escapeString","string","replace","a","c","charCodeAt","toString","padStart","quoteString","readAsPromised","stream","size","resolve","reject","endListener","recursiveResolve","promise","res","resType","JsonStreamStringify","replacer","spaces","cycle","gap","spaceType","repeat","Function","addToStack","key","existingPath","visited","get","path","undefined","push","map","v","set","length","join","index","realValue","replacerFunction","toJSON","replacerArray","includes","type","_push","depth","cycler","has","Error","add","open","obj","unread","isEmpty","keys","startsWith","ended","emit","flowing","pause","readCount","end","__read","err","error","first","stack","unshift","item","isObject","delete","addSeparatorAfterEnd","splice","indexOf","data","pushCalled","current","removeFromStack","shift","processObject","String","out","isRunning","readMore","processStackTopItem","readAgain","catch","filter","reverse","Readable"],"mappings":";;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;AAEA,IAAMA,cAAc,iIAApB;;AAGA,IAAMC,OAAO;QACL,KADK;QAEL,KAFK;QAGL,KAHK;QAIL,KAJK;QAKL,KALK;OAMN,KANM;QAOL;CAPR;;AAUA,SAASC,gBAAT,CAA0BC,KAA1B,EAAiC;SACxB,OAAOA,MAAMC,IAAb,KAAsB,UAAtB,IACE,OAAOD,MAAME,IAAb,KAAsB,UADxB,IAEE,OAAOF,MAAMG,cAAb,KAAgC,UAFlC,IAGE,QAAOH,MAAMI,cAAb,MAAgC,QAHzC;;;AAMF,SAASC,OAAT,CAAiBL,KAAjB,EAAwB;MAClB,CAACA,KAAL,EAAY,OAAO,WAAP;MACR,OAAOA,MAAMM,IAAb,KAAsB,UAA1B,EAAsC,OAAO,SAAP;MAClCP,iBAAiBC,KAAjB,CAAJ,EAA6B,yBAAkBA,MAAMI,cAAN,CAAqBG,UAArB,GAAkC,QAAlC,GAA6C,QAA/D;MACzBC,MAAMC,OAAN,CAAcT,KAAd,CAAJ,EAA0B,OAAO,OAAP;MACtB,QAAOA,KAAP,MAAiB,QAAjB,IAA6BA,iBAAiBU,MAAlD,EAA0D,OAAO,QAAP;SACnD,WAAP;;;AAGF,IAAMC,eAAe;SACZ,GADY;UAEX,GAFW;kBAGH,GAHG;kBAIH;CAJlB;AAOA,IAAMC,gBAAgB;SACb,GADa;UAEZ,GAFY;kBAGJ,GAHI;kBAIJ;CAJlB;;AAOA,SAASC,YAAT,CAAsBC,MAAtB,EAA8B;;;;;;;SASrBA,OAAOC,OAAP,CAAelB,WAAf,EAA4B,UAACmB,CAAD,EAAO;QAClCC,IAAInB,KAAKkB,CAAL,CAAV;WACO,OAAOC,CAAP,KAAa,QAAb,GAAwBA,CAAxB,gBAAkCD,EAAEE,UAAF,CAAa,CAAb,EAAgBC,QAAhB,CAAyB,EAAzB,EAA6BC,QAA7B,CAAsC,CAAtC,EAAyC,GAAzC,CAAlC,CAAP;GAFK,CAAP;;;AAMF,SAASC,WAAT,CAAqBP,MAArB,EAA6B;qBAChBD,aAAaC,MAAb,CAAX;;;AAGF,SAASQ,cAAT,CAAwBC,MAAxB,EAAgCC,IAAhC,EAAsC;MAC9BxB,QAAQuB,OAAOtB,IAAP,CAAYuB,IAAZ,CAAd;;MACIxB,UAAU,IAAd,EAAoB;WACX,aAAY,UAACyB,OAAD,EAAUC,MAAV,EAAqB;UAChCC,cAAc,SAAdA,WAAc;eAAMF,QAAQ,IAAR,CAAN;OAApB;;aACOvB,IAAP,CAAY,KAAZ,EAAmByB,WAAnB;aACOzB,IAAP,CAAY,OAAZ,EAAqBwB,MAArB;aACOxB,IAAP,CAAY,UAAZ,EAAwB,YAAM;eACrBC,cAAP,CAAsB,KAAtB,EAA6BwB,WAA7B;eACOxB,cAAP,CAAsB,OAAtB,EAA+BuB,MAA/B;gBACQH,OAAOtB,IAAP,EAAR;OAHF;KAJK,CAAP;;;SAWK,SAAQwB,OAAR,CAAgBzB,KAAhB,CAAP;;;AAGF,SAAS4B,gBAAT,CAA0BC,OAA1B,EAAmC;SAC1BA,QAAQvB,IAAR,CAAa,UAACwB,GAAD,EAAS;QACrBC,UAAU1B,QAAQyB,GAAR,CAAhB;WACOC,YAAY,SAAZ,GAAwBH,iBAAiBE,GAAjB,CAAxB,GAAgDA,GAAvD;GAFK,CAAP;;;IAMIE;;;;;+BACQhC,KAAZ,EAAmBiC,QAAnB,EAA6BC,MAA7B,EAAqCC,KAArC,EAA4C;;;;;6FACpC,EAAN;QACIC,GAAJ;;QACMC,oBAAmBH,MAAnB,CAAN;;QACIG,cAAc,QAAd,IAA0BA,cAAc,QAA5C,EAAsD;YAC9C,iBAAgBH,MAAhB,IAA0B,IAAII,MAAJ,CAAWJ,MAAX,CAA1B,GAA+CA,MAArD;;;0EAEkB;eACTC,QAAQ,cAAR,GAAwB,cADf;kBAAA;aAGX,EAHW;wBAIAF,oBAAoBM,QAApB,IAAgCN,QAJhC;qBAKHzB,MAAMC,OAAN,CAAcwB,QAAd,KAA2BA,QALxB;cAAA;aAOX;KAPT;;UASKO,UAAL,CAAgBxC,KAAhB;;;;;;;2BAGKyC,KAAKzC,OAAO;UACX0C,eAAe,KAAKC,OAAL,CAAaC,GAAb,CAAiB5C,KAAjB,CAArB;;UACI0C,YAAJ,EAAkB;eACT;gBACCA;SADR;;;UAIEG,OAAO,KAAKA,IAAL,EAAX;UACIJ,QAAQK,SAAZ,EAAuBD,KAAKE,IAAL,CAAUN,GAAV;aAChBI,KAAKG,GAAL,CAAS;0BAAU,kBAAiBC,CAAjB,IAAsBA,CAAtB,GAA0B5B,YAAY4B,CAAZ,CAApC;OAAT,CAAP;WACKN,OAAL,CAAaO,GAAb,CAAiBlD,KAAjB,EAAwB6C,KAAKM,MAAL,cAAkBN,KAAKO,IAAL,CAAU,EAAV,CAAlB,IAAoC,GAA5D;aACOpD,KAAP;;;;+BAGSA,OAAOyC,KAAKY,OAAO;;;UACxBC,YAAYtD,KAAhB;;UACI,KAAKuD,gBAAT,EAA2B;oBACb,KAAKA,gBAAL,CAAsBd,OAAOY,KAA7B,EAAoCC,SAApC,EAA+C,IAA/C,CAAZ;OAH0B;;;UAMxBA,aAAaA,UAAUE,MAAV,YAA4BjB,QAA7C,EAAuD;oBACzCe,UAAUE,MAAV,EAAZ;;;UAEEF,qBAAqBf,QAArB,IAAiC,QAAOvC,KAAP,MAAiB,QAAtD,EAAgE;oBAClD8C,SAAZ;;;UAEEL,QAAQK,SAAR,IAAqB,KAAKW,aAA9B,EAA6C;YACvC,CAAC,KAAKA,aAAL,CAAmBC,QAAnB,CAA4BjB,GAA5B,CAAL,EAAuC;sBACzBK,SAAZ;;;;UAGAa,OAAOtD,QAAQiD,SAAR,CAAX;;UACIA,cAAcR,SAAd,IAA2Ba,SAAS,SAApC,IAAiDlB,GAArD,EAA0D;YACpD,KAAKL,GAAT,EAAc;eACPwB,KAAL,aAAgB,KAAKxB,GAAL,CAASE,MAAT,CAAgB,KAAKuB,KAArB,CAAhB,eAA+ChD,aAAa4B,GAAb,CAA/C;SADF,MAEO;eACAmB,KAAL,aAAe/C,aAAa4B,GAAb,CAAf;;;;UAGAkB,SAAS,WAAb,EAA0B;YACpB,KAAKxB,KAAT,EAAgB;;sBAEF,KAAK2B,MAAL,CAAYrB,OAAOY,KAAnB,EAA0BC,SAA1B,CAAZ;iBACOjD,QAAQiD,SAAR,CAAP;SAHF,MAIO;;cAED,KAAKX,OAAL,CAAaoB,GAAb,CAAiBT,SAAjB,CAAJ,EAAiC;kBACzB,eAAc,IAAIU,KAAJ,CAAU,uCAAV,CAAd,EAAkE;kCAAA;mBAEjEvB,OAAOY;aAFR,CAAN;;;eAKGV,OAAL,CAAasB,GAAb,CAAiBX,SAAjB;;;;UAIA,CAACb,GAAD,IAAQY,QAAQ,CAAC,CAAjB,IAAsB,KAAKQ,KAA3B,IAAoC,KAAKzB,GAA7C,EAAkD,KAAKwB,KAAL,aAAgB,KAAKxB,GAAL,CAASE,MAAT,CAAgB,KAAKuB,KAArB,CAAhB;UAE5CK,OAAOtD,cAAc+C,IAAd,CAAb;UACIO,IAAJ,EAAU,KAAKN,KAAL,CAAWM,IAAX;UAEJC,MAAM;gBAAA;oBAAA;kBAAA;eAIHb;OAJT;;UAOIK,SAAS,QAAb,EAAuB;aAChBE,KAAL,IAAc,CAAd;YACIO,MAAJ,GAAa,aAAYd,SAAZ,CAAb;YACIe,OAAJ,GAAc,CAACF,IAAIC,MAAJ,CAAWjB,MAA1B;OAHF,MAIO,IAAIQ,SAAS,OAAb,EAAsB;aACtBE,KAAL,IAAc,CAAd;YACIO,MAAJ,GAAa,YAAW5D,MAAM8C,UAAUH,MAAhB,EAAwBmB,IAAxB,EAAX,CAAb;YACID,OAAJ,GAAc,CAACF,IAAIC,MAAJ,CAAWjB,MAA1B;OAHK,MAIA,IAAIQ,KAAKY,UAAL,CAAgB,UAAhB,CAAJ,EAAiC;aACjCV,KAAL,IAAc,CAAd;;YACIP,UAAUlD,cAAV,CAAyBoE,KAA7B,EAAoC;eAC7BC,IAAL,CAAU,OAAV,EAAmB,IAAIT,KAAJ,CAAU,oFAAV,CAAnB,EAAoHV,SAApH,EAA+Hb,OAAOY,KAAtI;SADF,MAEO,IAAIC,UAAUlD,cAAV,CAAyBsE,OAA7B,EAAsC;oBACjCC,KAAV;eACKF,IAAL,CAAU,OAAV,EAAmB,IAAIT,KAAJ,CAAU,sFAAV,CAAnB,EAAsHV,SAAtH,EAAiIb,OAAOY,KAAxI;;;YAEEuB,SAAJ,GAAgB,CAAhB;kBACU1E,IAAV,CAAe,KAAf,EAAsB,YAAM;cACtB2E,GAAJ,GAAU,IAAV;;iBACKC,MAAL;SAFF;kBAIU5E,IAAV,CAAe,OAAf,EAAwB,UAAC6E,GAAD,EAAS;iBAC1BC,KAAL,GAAa,IAAb;;iBACKP,IAAL,CAAU,OAAV,EAAmBM,GAAnB;SAFF;YAIIE,KAAJ,GAAY,IAAZ;;;WAEGC,KAAL,CAAWC,OAAX,CAAmBhB,GAAnB;aACOA,GAAP;;;;oCAGciB,MAAM;UAElBzB,IAFkB,GAGhByB,IAHgB,CAElBzB,IAFkB;UAId0B,WAAW1B,SAAS,QAAT,IAAqBA,SAAS,OAA9B,IAAyCA,KAAKY,UAAL,CAAgB,UAAhB,CAA1D;;UACIZ,SAAS,WAAb,EAA0B;YACpB,CAAC,KAAKxB,KAAV,EAAiB;eACVQ,OAAL,CAAa2C,MAAb,CAAoBF,KAAKpF,KAAzB;;;YAEEqF,QAAJ,EAAc;eACPxB,KAAL,IAAc,CAAd;;;;UAIEgB,MAAMlE,aAAagD,IAAb,CAAZ;UACI0B,YAAY,CAACD,KAAKf,OAAlB,IAA6B,KAAKjC,GAAtC,EAA2C,KAAKwB,KAAL,aAAgB,KAAKxB,GAAL,CAASE,MAAT,CAAgB,KAAKuB,KAArB,CAAhB;UACvCgB,GAAJ,EAAS,KAAKjB,KAAL,CAAWiB,GAAX;;UACLO,KAAKG,oBAAT,EAA+B;aACxB3B,KAAL,CAAW,GAAX;;;WAEGsB,KAAL,CAAWM,MAAX,CAAkB,KAAKN,KAAL,CAAWO,OAAX,CAAmBL,IAAnB,CAAlB,EAA4C,CAA5C;;;;0BAGIM,MAAM;WACLC,UAAL,GAAkB,IAAlB;WACK5C,IAAL,CAAU2C,IAAV;;;;0CAGoBE,SAASpE,MAAM;;;UAC/BoE,QAAQf,GAAZ,EAAiB;aACVgB,eAAL,CAAqBD,OAArB;eACO9C,SAAP;;;aAEKxB,eAAesE,QAAQ5F,KAAvB,EAA8BwB,IAA9B,EACJlB,IADI,CACC,UAACN,KAAD,EAAW;YACXA,UAAU,IAAd,EAAoB;cACd,CAAC4F,QAAQX,KAAb,EAAoB;mBACbrB,KAAL,CAAW,GAAX;;;;;kBAGMqB,KAAR,GAAgB,KAAhB;;iBACKzC,UAAL,CAAgBxC,KAAhB,EAAuB8C,SAAvB,EAAkC8C,QAAQhB,SAA1C;;kBACQA,SAAR,IAAqB,CAArB;;;OATC,CAAP;;;;kCAeYgB,SAAS;UACjB,CAACA,QAAQxB,MAAR,CAAejB,MAApB,EAA4B;aACrB0C,eAAL,CAAqBD,OAArB;;;;UAGInD,MAAMmD,QAAQxB,MAAR,CAAe0B,KAAf,EAAZ;UACM9F,QAAQ4F,QAAQ5F,KAAR,CAAcyC,GAAd,CAAd;WAEKD,UAAL,CAAgBxC,KAAhB,EAAuB4F,QAAQjC,IAAR,KAAiB,QAAjB,IAA6BlB,GAApD,EAAyDmD,QAAQjC,IAAR,KAAiB,OAAjB,IAA4BlB,GAArF,EAA0F8C,oBAA1F,GAAiH,CAAC,CAACK,QAAQxB,MAAR,CAAejB,MAAlI;;;;iCAGWyC,SAAS;aACb,KAAKG,aAAL,CAAmBH,OAAnB,CAAP;;;;qCAGeA,SAAS;UACpBA,QAAQ5F,KAAR,KAAkB8C,SAAtB,EAAiC;YACzBa,eAAciC,QAAQ5F,KAAtB,CAAN;;YACIA,KAAJ;;gBACQ2D,IAAR;eACK,QAAL;oBACUtC,YAAYuE,QAAQ5F,KAApB,CAAR;;;eAEG,QAAL;oBACU,iBAAgB4F,QAAQ5F,KAAxB,IAAiCgG,OAAOJ,QAAQ5F,KAAf,CAAjC,GAAyD,MAAjE;;;eAEG,SAAL;eACK,MAAL;oBACUgG,OAAOJ,QAAQ5F,KAAf,CAAR;;;eAEG,QAAL;gBACM,CAAC4F,QAAQ5F,KAAb,EAAoB;sBACV,MAAR;;;;;;;;;kBAOI,eAAc,IAAIgE,KAAJ,0BAA2BL,IAA3B,+BAAd,EAA0E;qBACvEiC,QAAQ5F;aADX,CAAN;;;aAIG4D,KAAL,CAAW5D,KAAX;OA3BF,MA4BO,IAAI,KAAKkF,KAAL,CAAW,CAAX,MAAkB,KAAKA,KAAL,CAAW,CAAX,EAAcvB,IAAd,KAAuB,OAAvB,IAAkC,KAAKuB,KAAL,CAAW,CAAX,EAAcvB,IAAd,KAAuB,gBAA3E,CAAJ,EAAkG;aAClGC,KAAL,CAAW,MAAX;OADK,MAEA;;gBAEG2B,oBAAR,GAA+B,KAA/B;;;WAEGM,eAAL,CAAqBD,OAArB;;;;0CAGoBA,SAASpE,MAAM;;;UAC/BoE,QAAQf,GAAZ,EAAiB;aACVgB,eAAL,CAAqBD,OAArB;eACO9C,SAAP;;;aAEKxB,eAAesE,QAAQ5F,KAAvB,EAA8BwB,IAA9B,EACJlB,IADI,CACC,UAACN,KAAD,EAAW;YACXA,KAAJ,EAAW,OAAK4D,KAAL,CAAW/C,aAAab,MAAMmB,QAAN,EAAb,CAAX;OAFR,CAAP;;;;mCAMayE,SAAS;;;aACfhE,iBAAiBgE,QAAQ5F,KAAzB,EAAgCM,IAAhC,CAAqC,UAACN,KAAD,EAAW;YAEnDuF,oBAFmD,GAGjDK,OAHiD,CAEnDL,oBAFmD;;;gBAK7CA,oBAAR,GAA+B,KAA/B;;eACKM,eAAL,CAAqBD,OAArB;;eACKpD,UAAL,CAAgBxC,KAAhB,EAAuB4F,QAAQnD,GAA/B,EAAoCmD,QAAQvC,KAA5C,EACGkC,oBADH,GAC0BA,oBAD1B;OAPK,CAAP;;;;wCAYkB/D,MAAM;;;UAClBoE,UAAU,KAAKV,KAAL,CAAW,CAAX,CAAhB;UACI,CAACU,OAAD,IAAY,KAAKZ,KAArB,EAA4B,OAAO,SAAQvD,OAAR,EAAP;UACxBwE,GAAJ;;UACI;cACI,sBAAeL,QAAQjC,IAAvB,GAA+BiC,OAA/B,EAAwCpE,IAAxC,CAAN;OADF,CAEE,OAAOuD,GAAP,EAAY;eACL,SAAQrD,MAAR,CAAeqD,GAAf,CAAP;;;aAEK,SAAQtD,OAAR,CAAgBwE,GAAhB,EACJ3F,IADI,CACC,YAAM;YACN,OAAK4E,KAAL,CAAW/B,MAAX,KAAsB,CAA1B,EAA6B;iBACtB0B,GAAL,GAAW,IAAX;;iBACKjB,KAAL,CAAW,IAAX;;OAJC,CAAP;;;;2BASKpC,MAAM;;;UACP,KAAK0E,SAAL,IAAkB,KAAKlB,KAA3B,EAAkC;aAC3BmB,QAAL,GAAgB,IAAhB;eACOrD,SAAP;;;WAEGoD,SAAL,GAAiB,IAAjB,CALW;;WAQNC,QAAL,GAAgB,KAAhB;aACO,KAAKC,mBAAL,CAAyB5E,IAAzB,EACJlB,IADI,CACC,YAAM;YACJ+F,YAAY,CAAC,OAAKxB,GAAN,IAAa,CAAC,OAAKG,KAAnB,KAA6B,OAAKmB,QAAL,IAAiB,CAAC,OAAKR,UAApD,CAAlB;;YACIU,SAAJ,EAAe;wBACA,YAAM;mBACZH,SAAL,GAAiB,KAAjB;;mBACKpB,MAAL;WAFF;SADF,MAKO;iBACAoB,SAAL,GAAiB,KAAjB;;OATC,EAYJI,KAZI,CAYE,UAACvB,GAAD,EAAS;eACTC,KAAL,GAAa,IAAb;;eACKP,IAAL,CAAU,OAAV,EAAmBM,GAAnB;OAdG,CAAP;;;;0BAkBIvD,MAAM;WACLmE,UAAL,GAAkB,KAAlB;;WACKb,MAAL,CAAYtD,IAAZ;;;;2BAGK;aACE,KAAK0D,KAAL,CAAWlC,GAAX,CAAe;YACpBP,GADoB,QACpBA,GADoB;YAEpBY,KAFoB,QAEpBA,KAFoB;eAGhBZ,OAAOY,KAHS;OAAf,EAGakD,MAHb,CAGoB;eAAKtD,KAAKA,IAAI,CAAC,CAAf;OAHpB,EAGsCuD,OAHtC,EAAP;;;;;EAvS8BC;;;;"} |
+560
| (function (global, factory) { | ||
| typeof exports === 'object' && typeof module !== 'undefined' ? module.exports = factory(require('stream')) : | ||
| typeof define === 'function' && define.amd ? define(['stream'], factory) : | ||
| (global.jsonStreamStringify = factory(global.stream)); | ||
| }(this, (function (stream) { 'use strict'; | ||
| 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 _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 _inherits(subClass, superClass) { | ||
| if (typeof superClass !== "function" && superClass !== null) { | ||
| throw new TypeError("Super expression must either be null or a function"); | ||
| } | ||
| subClass.prototype = Object.create(superClass && superClass.prototype, { | ||
| constructor: { | ||
| value: subClass, | ||
| writable: true, | ||
| configurable: true | ||
| } | ||
| }); | ||
| if (superClass) _setPrototypeOf(subClass, superClass); | ||
| } | ||
| function _getPrototypeOf(o) { | ||
| _getPrototypeOf = Object.setPrototypeOf ? Object.getPrototypeOf : function _getPrototypeOf(o) { | ||
| return o.__proto__ || Object.getPrototypeOf(o); | ||
| }; | ||
| return _getPrototypeOf(o); | ||
| } | ||
| function _setPrototypeOf(o, p) { | ||
| _setPrototypeOf = Object.setPrototypeOf || function _setPrototypeOf(o, p) { | ||
| o.__proto__ = p; | ||
| return o; | ||
| }; | ||
| return _setPrototypeOf(o, p); | ||
| } | ||
| function _assertThisInitialized(self) { | ||
| if (self === void 0) { | ||
| throw new ReferenceError("this hasn't been initialised - super() hasn't been called"); | ||
| } | ||
| return self; | ||
| } | ||
| function _possibleConstructorReturn(self, call) { | ||
| if (call && (typeof call === "object" || typeof call === "function")) { | ||
| return call; | ||
| } | ||
| return _assertThisInitialized(self); | ||
| } | ||
| var rxEscapable = /[\\"\u0000-\u001f\u007f-\u009f\u00ad\u0600-\u0604\u070f\u17b4\u17b5\u200c-\u200f\u2028-\u202f\u2060-\u206f\ufeff\ufff0-\uffff]/g; // table of character substitutions | ||
| var meta = { | ||
| '\b': '\\b', | ||
| '\t': '\\t', | ||
| '\n': '\\n', | ||
| '\f': '\\f', | ||
| '\r': '\\r', | ||
| '"': '\\"', | ||
| '\\': '\\\\' | ||
| }; | ||
| function isReadableStream(value) { | ||
| return typeof value.read === 'function' && typeof value.once === 'function' && typeof value.removeListener === 'function' && _typeof(value._readableState) === 'object'; | ||
| } | ||
| function getType(value) { | ||
| if (!value) return 'Primitive'; | ||
| if (typeof value.then === 'function') return 'Promise'; | ||
| if (isReadableStream(value)) return "Readable".concat(value._readableState.objectMode ? 'Object' : 'String'); | ||
| if (Array.isArray(value)) return 'Array'; | ||
| if (_typeof(value) === 'object' || value instanceof Object) return 'Object'; | ||
| return 'Primitive'; | ||
| } | ||
| var stackItemEnd = { | ||
| Array: ']', | ||
| Object: '}', | ||
| ReadableString: '"', | ||
| ReadableObject: ']' | ||
| }; | ||
| var stackItemOpen = { | ||
| Array: '[', | ||
| Object: '{', | ||
| ReadableString: '"', | ||
| ReadableObject: '[' | ||
| }; | ||
| function escapeString(string) { | ||
| // Modified code, original code by Douglas Crockford | ||
| // Original: https://github.com/douglascrockford/JSON-js/blob/master/json2.js | ||
| // If the string contains no control characters, no quote characters, and no | ||
| // backslash characters, then we can safely slap some quotes around it. | ||
| // Otherwise we must also replace the offending characters with safe escape | ||
| // sequences. | ||
| return string.replace(rxEscapable, function (a) { | ||
| var c = meta[a]; | ||
| return typeof c === 'string' ? c : "\\u".concat(a.charCodeAt(0).toString(16).padStart(4, '0')); | ||
| }); | ||
| } | ||
| function quoteString(string) { | ||
| return "\"".concat(escapeString(string), "\""); | ||
| } | ||
| function readAsPromised(stream$$1, size) { | ||
| var value = stream$$1.read(size); | ||
| if (value === null) { | ||
| return new Promise(function (resolve, reject) { | ||
| var endListener = function endListener() { | ||
| return resolve(null); | ||
| }; | ||
| stream$$1.once('end', endListener); | ||
| stream$$1.once('error', reject); | ||
| stream$$1.once('readable', function () { | ||
| stream$$1.removeListener('end', endListener); | ||
| stream$$1.removeListener('error', reject); | ||
| resolve(stream$$1.read()); | ||
| }); | ||
| }); | ||
| } | ||
| return Promise.resolve(value); | ||
| } | ||
| function recursiveResolve(promise) { | ||
| return promise.then(function (res) { | ||
| var resType = getType(res); | ||
| return resType === 'Promise' ? recursiveResolve(res) : res; | ||
| }); | ||
| } | ||
| var JsonStreamStringify = | ||
| /*#__PURE__*/ | ||
| function (_Readable) { | ||
| _inherits(JsonStreamStringify, _Readable); | ||
| function JsonStreamStringify(value, replacer, spaces, cycle) { | ||
| var _this; | ||
| _classCallCheck(this, JsonStreamStringify); | ||
| _this = _possibleConstructorReturn(this, _getPrototypeOf(JsonStreamStringify).call(this, {})); | ||
| var gap; | ||
| var spaceType = _typeof(spaces); | ||
| if (spaceType === 'string' || spaceType === 'number') { | ||
| gap = Number.isFinite(spaces) ? ' '.repeat(spaces) : spaces; | ||
| } | ||
| Object.assign(_assertThisInitialized(_assertThisInitialized(_this)), { | ||
| visited: cycle ? new WeakMap() : new WeakSet(), | ||
| cycle: cycle, | ||
| stack: [], | ||
| replacerFunction: replacer instanceof Function && replacer, | ||
| replacerArray: Array.isArray(replacer) && replacer, | ||
| gap: gap, | ||
| depth: 0 | ||
| }); | ||
| _this.addToStack(value); | ||
| return _this; | ||
| } | ||
| _createClass(JsonStreamStringify, [{ | ||
| key: "cycler", | ||
| value: function cycler(key, value) { | ||
| var existingPath = this.visited.get(value); | ||
| if (existingPath) { | ||
| return { | ||
| $ref: existingPath | ||
| }; | ||
| } | ||
| var path = this.path(); | ||
| if (key !== undefined) path.push(key); | ||
| path = path.map(function (v) { | ||
| return "[".concat(Number.isInteger(v) ? v : quoteString(v), "]"); | ||
| }); | ||
| this.visited.set(value, path.length ? "$".concat(path.join('')) : '$'); | ||
| return value; | ||
| } | ||
| }, { | ||
| key: "addToStack", | ||
| value: function addToStack(value, key, index) { | ||
| var _this2 = this; | ||
| var realValue = value; | ||
| if (this.replacerFunction) { | ||
| realValue = this.replacerFunction(key || index, realValue, this); | ||
| } // ORDER? | ||
| if (realValue && realValue.toJSON instanceof Function) { | ||
| realValue = realValue.toJSON(); | ||
| } | ||
| if (realValue instanceof Function || _typeof(value) === 'symbol') { | ||
| realValue = undefined; | ||
| } | ||
| if (key !== undefined && this.replacerArray) { | ||
| if (!this.replacerArray.includes(key)) { | ||
| realValue = undefined; | ||
| } | ||
| } | ||
| var type = getType(realValue); | ||
| if (realValue !== undefined && type !== 'Promise' && key) { | ||
| if (this.gap) { | ||
| this._push("\n".concat(this.gap.repeat(this.depth), "\"").concat(escapeString(key), "\": ")); | ||
| } else { | ||
| this._push("\"".concat(escapeString(key), "\":")); | ||
| } | ||
| } | ||
| if (type !== 'Primitive') { | ||
| if (this.cycle) { | ||
| // run cycler | ||
| realValue = this.cycler(key || index, realValue); | ||
| type = getType(realValue); | ||
| } else { | ||
| // check for circular structure | ||
| if (this.visited.has(realValue)) { | ||
| throw Object.assign(new Error('Converting circular structure to JSON'), { | ||
| realValue: realValue, | ||
| key: key || index | ||
| }); | ||
| } | ||
| this.visited.add(realValue); | ||
| } | ||
| } | ||
| if (!key && index > -1 && this.depth && this.gap) this._push("\n".concat(this.gap.repeat(this.depth))); | ||
| var open = stackItemOpen[type]; | ||
| if (open) this._push(open); | ||
| var obj = { | ||
| key: key, | ||
| index: index, | ||
| type: type, | ||
| value: realValue | ||
| }; | ||
| if (type === 'Object') { | ||
| this.depth += 1; | ||
| obj.unread = Object.keys(realValue); | ||
| obj.isEmpty = !obj.unread.length; | ||
| } else if (type === 'Array') { | ||
| this.depth += 1; | ||
| obj.unread = Array.from(Array(realValue.length).keys()); | ||
| obj.isEmpty = !obj.unread.length; | ||
| } else if (type.startsWith('Readable')) { | ||
| this.depth += 1; | ||
| if (realValue._readableState.ended) { | ||
| this.emit('error', new Error('Readable Stream has ended before it was serialized. All stream data have been lost'), realValue, key || index); | ||
| } else if (realValue._readableState.flowing) { | ||
| realValue.pause(); | ||
| this.emit('error', new Error('Readable Stream is in flowing mode, data may have been lost. Trying to pause stream.'), realValue, key || index); | ||
| } | ||
| obj.readCount = 0; | ||
| realValue.once('end', function () { | ||
| obj.end = true; | ||
| _this2.__read(); | ||
| }); | ||
| realValue.once('error', function (err) { | ||
| _this2.error = true; | ||
| _this2.emit('error', err); | ||
| }); | ||
| obj.first = true; | ||
| } | ||
| this.stack.unshift(obj); | ||
| return obj; | ||
| } | ||
| }, { | ||
| key: "removeFromStack", | ||
| value: function removeFromStack(item) { | ||
| var type = item.type; | ||
| var isObject = type === 'Object' || type === 'Array' || type.startsWith('Readable'); | ||
| if (type !== 'Primitive') { | ||
| if (!this.cycle) { | ||
| this.visited.delete(item.value); | ||
| } | ||
| if (isObject) { | ||
| this.depth -= 1; | ||
| } | ||
| } | ||
| var end = stackItemEnd[type]; | ||
| if (isObject && !item.isEmpty && this.gap) this._push("\n".concat(this.gap.repeat(this.depth))); | ||
| if (end) this._push(end); | ||
| if (item.addSeparatorAfterEnd) { | ||
| this._push(','); | ||
| } | ||
| this.stack.splice(this.stack.indexOf(item), 1); | ||
| } | ||
| }, { | ||
| key: "_push", | ||
| value: function _push(data) { | ||
| this.pushCalled = true; | ||
| this.push(data); | ||
| } | ||
| }, { | ||
| key: "processReadableObject", | ||
| value: function processReadableObject(current, size) { | ||
| var _this3 = this; | ||
| if (current.end) { | ||
| this.removeFromStack(current); | ||
| return undefined; | ||
| } | ||
| return readAsPromised(current.value, size).then(function (value) { | ||
| if (value !== null) { | ||
| if (!current.first) { | ||
| _this3._push(','); | ||
| } | ||
| /* eslint-disable no-param-reassign */ | ||
| current.first = false; | ||
| _this3.addToStack(value, undefined, current.readCount); | ||
| current.readCount += 1; | ||
| /* eslint-enable no-param-reassign */ | ||
| } | ||
| }); | ||
| } | ||
| }, { | ||
| key: "processObject", | ||
| value: function processObject(current) { | ||
| if (!current.unread.length) { | ||
| this.removeFromStack(current); | ||
| return; | ||
| } | ||
| var key = current.unread.shift(); | ||
| var value = current.value[key]; | ||
| this.addToStack(value, current.type === 'Object' && key, current.type === 'Array' && key).addSeparatorAfterEnd = !!current.unread.length; | ||
| } | ||
| }, { | ||
| key: "processArray", | ||
| value: function processArray(current) { | ||
| return this.processObject(current); | ||
| } | ||
| }, { | ||
| key: "processPrimitive", | ||
| value: function processPrimitive(current) { | ||
| if (current.value !== undefined) { | ||
| var type = _typeof(current.value); | ||
| var value; | ||
| switch (type) { | ||
| case 'string': | ||
| value = quoteString(current.value); | ||
| break; | ||
| case 'number': | ||
| value = Number.isFinite(current.value) ? String(current.value) : 'null'; | ||
| break; | ||
| case 'boolean': | ||
| case 'null': | ||
| value = String(current.value); | ||
| break; | ||
| case 'object': | ||
| if (!current.value) { | ||
| value = 'null'; | ||
| break; | ||
| } | ||
| /* eslint-disable-next-line no-fallthrough */ | ||
| default: | ||
| // This should never happen, I can't imagine a situation where this executes. | ||
| // If you find a way, please open a ticket or PR | ||
| throw Object.assign(new Error("Unknown type \"".concat(type, "\". Please file an issue!")), { | ||
| value: current.value | ||
| }); | ||
| } | ||
| this._push(value); | ||
| } else if (this.stack[1] && (this.stack[1].type === 'Array' || this.stack[1].type === 'ReadableObject')) { | ||
| this._push('null'); | ||
| } else { | ||
| /* eslint-disable-next-line no-param-reassign */ | ||
| current.addSeparatorAfterEnd = false; | ||
| } | ||
| this.removeFromStack(current); | ||
| } | ||
| }, { | ||
| key: "processReadableString", | ||
| value: function processReadableString(current, size) { | ||
| var _this4 = this; | ||
| if (current.end) { | ||
| this.removeFromStack(current); | ||
| return undefined; | ||
| } | ||
| return readAsPromised(current.value, size).then(function (value) { | ||
| if (value) _this4._push(escapeString(value.toString())); | ||
| }); | ||
| } | ||
| }, { | ||
| key: "processPromise", | ||
| value: function processPromise(current) { | ||
| var _this5 = this; | ||
| return recursiveResolve(current.value).then(function (value) { | ||
| var addSeparatorAfterEnd = current.addSeparatorAfterEnd; | ||
| /* eslint-disable-next-line no-param-reassign */ | ||
| current.addSeparatorAfterEnd = false; | ||
| _this5.removeFromStack(current); | ||
| _this5.addToStack(value, current.key, current.index).addSeparatorAfterEnd = addSeparatorAfterEnd; | ||
| }); | ||
| } | ||
| }, { | ||
| key: "processStackTopItem", | ||
| value: function processStackTopItem(size) { | ||
| var _this6 = this; | ||
| var current = this.stack[0]; | ||
| if (!current || this.error) return Promise.resolve(); | ||
| var out; | ||
| try { | ||
| out = this["process".concat(current.type)](current, size); | ||
| } catch (err) { | ||
| return Promise.reject(err); | ||
| } | ||
| return Promise.resolve(out).then(function () { | ||
| if (_this6.stack.length === 0) { | ||
| _this6.end = true; | ||
| _this6._push(null); | ||
| } | ||
| }); | ||
| } | ||
| }, { | ||
| key: "__read", | ||
| value: function __read(size) { | ||
| var _this7 = this; | ||
| if (this.isRunning || this.error) { | ||
| this.readMore = true; | ||
| return undefined; | ||
| } | ||
| this.isRunning = true; // we must continue to read while push has not been called | ||
| this.readMore = false; | ||
| return this.processStackTopItem(size).then(function () { | ||
| var readAgain = !_this7.end && !_this7.error && (_this7.readMore || !_this7.pushCalled); | ||
| if (readAgain) { | ||
| setImmediate(function () { | ||
| _this7.isRunning = false; | ||
| _this7.__read(); | ||
| }); | ||
| } else { | ||
| _this7.isRunning = false; | ||
| } | ||
| }).catch(function (err) { | ||
| _this7.error = true; | ||
| _this7.emit('error', err); | ||
| }); | ||
| } | ||
| }, { | ||
| key: "_read", | ||
| value: function _read(size) { | ||
| this.pushCalled = false; | ||
| this.__read(size); | ||
| } | ||
| }, { | ||
| key: "path", | ||
| value: function path() { | ||
| return this.stack.map(function (_ref) { | ||
| var key = _ref.key, | ||
| index = _ref.index; | ||
| return key || index; | ||
| }).filter(function (v) { | ||
| return v || v > -1; | ||
| }).reverse(); | ||
| } | ||
| }]); | ||
| return JsonStreamStringify; | ||
| }(stream.Readable); | ||
| return JsonStreamStringify; | ||
| }))); | ||
| //# sourceMappingURL=umd.js.map |
| {"version":3,"file":"umd.js","sources":["../src/JsonStreamStringify.js"],"sourcesContent":["import { Readable } from 'stream';\n\nconst rxEscapable = /[\\\\\"\\u0000-\\u001f\\u007f-\\u009f\\u00ad\\u0600-\\u0604\\u070f\\u17b4\\u17b5\\u200c-\\u200f\\u2028-\\u202f\\u2060-\\u206f\\ufeff\\ufff0-\\uffff]/g;\n\n// table of character substitutions\nconst meta = {\n '\\b': '\\\\b',\n '\\t': '\\\\t',\n '\\n': '\\\\n',\n '\\f': '\\\\f',\n '\\r': '\\\\r',\n '\"': '\\\\\"',\n '\\\\': '\\\\\\\\',\n};\n\nfunction isReadableStream(value) {\n return typeof value.read === 'function'\n && typeof value.once === 'function'\n && typeof value.removeListener === 'function'\n && typeof value._readableState === 'object';\n}\n\nfunction getType(value) {\n if (!value) return 'Primitive';\n if (typeof value.then === 'function') return 'Promise';\n if (isReadableStream(value)) return `Readable${value._readableState.objectMode ? 'Object' : 'String'}`;\n if (Array.isArray(value)) return 'Array';\n if (typeof value === 'object' || value instanceof Object) return 'Object';\n return 'Primitive';\n}\n\nconst stackItemEnd = {\n Array: ']',\n Object: '}',\n ReadableString: '\"',\n ReadableObject: ']',\n};\n\nconst stackItemOpen = {\n Array: '[',\n Object: '{',\n ReadableString: '\"',\n ReadableObject: '[',\n};\n\nfunction escapeString(string) {\n // Modified code, original code by Douglas Crockford\n // Original: https://github.com/douglascrockford/JSON-js/blob/master/json2.js\n\n // If the string contains no control characters, no quote characters, and no\n // backslash characters, then we can safely slap some quotes around it.\n // Otherwise we must also replace the offending characters with safe escape\n // sequences.\n\n return string.replace(rxEscapable, (a) => {\n const c = meta[a];\n return typeof c === 'string' ? c : `\\\\u${a.charCodeAt(0).toString(16).padStart(4, '0')}`;\n });\n}\n\nfunction quoteString(string) {\n return `\"${escapeString(string)}\"`;\n}\n\nfunction readAsPromised(stream, size) {\n const value = stream.read(size);\n if (value === null) {\n return new Promise((resolve, reject) => {\n const endListener = () => resolve(null);\n stream.once('end', endListener);\n stream.once('error', reject);\n stream.once('readable', () => {\n stream.removeListener('end', endListener);\n stream.removeListener('error', reject);\n resolve(stream.read());\n });\n });\n }\n return Promise.resolve(value);\n}\n\nfunction recursiveResolve(promise) {\n return promise.then((res) => {\n const resType = getType(res);\n return resType === 'Promise' ? recursiveResolve(res) : res;\n });\n}\n\nclass JsonStreamStringify extends Readable {\n constructor(value, replacer, spaces, cycle) {\n super({});\n let gap;\n const spaceType = typeof spaces;\n if (spaceType === 'string' || spaceType === 'number') {\n gap = Number.isFinite(spaces) ? ' '.repeat(spaces) : spaces;\n }\n Object.assign(this, {\n visited: cycle ? new WeakMap() : new WeakSet(),\n cycle,\n stack: [],\n replacerFunction: replacer instanceof Function && replacer,\n replacerArray: Array.isArray(replacer) && replacer,\n gap,\n depth: 0,\n });\n this.addToStack(value);\n }\n\n cycler(key, value) {\n const existingPath = this.visited.get(value);\n if (existingPath) {\n return {\n $ref: existingPath,\n };\n }\n let path = this.path();\n if (key !== undefined) path.push(key);\n path = path.map(v => `[${(Number.isInteger(v) ? v : quoteString(v))}]`);\n this.visited.set(value, path.length ? `$${path.join('')}` : '$');\n return value;\n }\n\n addToStack(value, key, index) {\n let realValue = value;\n if (this.replacerFunction) {\n realValue = this.replacerFunction(key || index, realValue, this);\n }\n // ORDER?\n if (realValue && realValue.toJSON instanceof Function) {\n realValue = realValue.toJSON();\n }\n if (realValue instanceof Function || typeof value === 'symbol') {\n realValue = undefined;\n }\n if (key !== undefined && this.replacerArray) {\n if (!this.replacerArray.includes(key)) {\n realValue = undefined;\n }\n }\n let type = getType(realValue);\n if (realValue !== undefined && type !== 'Promise' && key) {\n if (this.gap) {\n this._push(`\\n${this.gap.repeat(this.depth)}\"${escapeString(key)}\": `);\n } else {\n this._push(`\"${escapeString(key)}\":`);\n }\n }\n if (type !== 'Primitive') {\n if (this.cycle) {\n // run cycler\n realValue = this.cycler(key || index, realValue);\n type = getType(realValue);\n } else {\n // check for circular structure\n if (this.visited.has(realValue)) {\n throw Object.assign(new Error('Converting circular structure to JSON'), {\n realValue,\n key: key || index,\n });\n }\n this.visited.add(realValue);\n }\n }\n\n if (!key && index > -1 && this.depth && this.gap) this._push(`\\n${this.gap.repeat(this.depth)}`);\n\n const open = stackItemOpen[type];\n if (open) this._push(open);\n\n const obj = {\n key,\n index,\n type,\n value: realValue,\n };\n\n if (type === 'Object') {\n this.depth += 1;\n obj.unread = Object.keys(realValue);\n obj.isEmpty = !obj.unread.length;\n } else if (type === 'Array') {\n this.depth += 1;\n obj.unread = Array.from(Array(realValue.length).keys());\n obj.isEmpty = !obj.unread.length;\n } else if (type.startsWith('Readable')) {\n this.depth += 1;\n if (realValue._readableState.ended) {\n this.emit('error', new Error('Readable Stream has ended before it was serialized. All stream data have been lost'), realValue, key || index);\n } else if (realValue._readableState.flowing) {\n realValue.pause();\n this.emit('error', new Error('Readable Stream is in flowing mode, data may have been lost. Trying to pause stream.'), realValue, key || index);\n }\n obj.readCount = 0;\n realValue.once('end', () => {\n obj.end = true;\n this.__read();\n });\n realValue.once('error', (err) => {\n this.error = true;\n this.emit('error', err);\n });\n obj.first = true;\n }\n this.stack.unshift(obj);\n return obj;\n }\n\n removeFromStack(item) {\n const {\n type,\n } = item;\n const isObject = type === 'Object' || type === 'Array' || type.startsWith('Readable');\n if (type !== 'Primitive') {\n if (!this.cycle) {\n this.visited.delete(item.value);\n }\n if (isObject) {\n this.depth -= 1;\n }\n }\n\n const end = stackItemEnd[type];\n if (isObject && !item.isEmpty && this.gap) this._push(`\\n${this.gap.repeat(this.depth)}`);\n if (end) this._push(end);\n if (item.addSeparatorAfterEnd) {\n this._push(',');\n }\n this.stack.splice(this.stack.indexOf(item), 1);\n }\n\n _push(data) {\n this.pushCalled = true;\n this.push(data);\n }\n\n processReadableObject(current, size) {\n if (current.end) {\n this.removeFromStack(current);\n return undefined;\n }\n return readAsPromised(current.value, size)\n .then((value) => {\n if (value !== null) {\n if (!current.first) {\n this._push(',');\n }\n /* eslint-disable no-param-reassign */\n current.first = false;\n this.addToStack(value, undefined, current.readCount);\n current.readCount += 1;\n /* eslint-enable no-param-reassign */\n }\n });\n }\n\n processObject(current) {\n if (!current.unread.length) {\n this.removeFromStack(current);\n return;\n }\n const key = current.unread.shift();\n const value = current.value[key];\n\n this.addToStack(value, current.type === 'Object' && key, current.type === 'Array' && key).addSeparatorAfterEnd = !!current.unread.length;\n }\n\n processArray(current) {\n return this.processObject(current);\n }\n\n processPrimitive(current) {\n if (current.value !== undefined) {\n const type = typeof current.value;\n let value;\n switch (type) {\n case 'string':\n value = quoteString(current.value);\n break;\n case 'number':\n value = Number.isFinite(current.value) ? String(current.value) : 'null';\n break;\n case 'boolean':\n case 'null':\n value = String(current.value);\n break;\n case 'object':\n if (!current.value) {\n value = 'null';\n break;\n }\n /* eslint-disable-next-line no-fallthrough */\n default:\n // This should never happen, I can't imagine a situation where this executes.\n // If you find a way, please open a ticket or PR\n throw Object.assign(new Error(`Unknown type \"${type}\". Please file an issue!`), {\n value: current.value,\n });\n }\n this._push(value);\n } else if (this.stack[1] && (this.stack[1].type === 'Array' || this.stack[1].type === 'ReadableObject')) {\n this._push('null');\n } else {\n /* eslint-disable-next-line no-param-reassign */\n current.addSeparatorAfterEnd = false;\n }\n this.removeFromStack(current);\n }\n\n processReadableString(current, size) {\n if (current.end) {\n this.removeFromStack(current);\n return undefined;\n }\n return readAsPromised(current.value, size)\n .then((value) => {\n if (value) this._push(escapeString(value.toString()));\n });\n }\n\n processPromise(current) {\n return recursiveResolve(current.value).then((value) => {\n const {\n addSeparatorAfterEnd,\n } = current;\n /* eslint-disable-next-line no-param-reassign */\n current.addSeparatorAfterEnd = false;\n this.removeFromStack(current);\n this.addToStack(value, current.key, current.index)\n .addSeparatorAfterEnd = addSeparatorAfterEnd;\n });\n }\n\n processStackTopItem(size) {\n const current = this.stack[0];\n if (!current || this.error) return Promise.resolve();\n let out;\n try {\n out = this[`process${current.type}`](current, size);\n } catch (err) {\n return Promise.reject(err);\n }\n return Promise.resolve(out)\n .then(() => {\n if (this.stack.length === 0) {\n this.end = true;\n this._push(null);\n }\n });\n }\n\n __read(size) {\n if (this.isRunning || this.error) {\n this.readMore = true;\n return undefined;\n }\n this.isRunning = true;\n\n // we must continue to read while push has not been called\n this.readMore = false;\n return this.processStackTopItem(size)\n .then(() => {\n const readAgain = !this.end && !this.error && (this.readMore || !this.pushCalled);\n if (readAgain) {\n setImmediate(() => {\n this.isRunning = false;\n this.__read();\n });\n } else {\n this.isRunning = false;\n }\n })\n .catch((err) => {\n this.error = true;\n this.emit('error', err);\n });\n }\n\n _read(size) {\n this.pushCalled = false;\n this.__read(size);\n }\n\n path() {\n return this.stack.map(({\n key,\n index,\n }) => key || index).filter(v => v || v > -1).reverse();\n }\n}\n\nexport default JsonStreamStringify;\n"],"names":["rxEscapable","meta","isReadableStream","value","read","once","removeListener","_readableState","getType","then","objectMode","Array","isArray","Object","stackItemEnd","ReadableString","ReadableObject","stackItemOpen","escapeString","string","replace","a","c","charCodeAt","toString","padStart","quoteString","readAsPromised","stream","size","Promise","resolve","reject","endListener","recursiveResolve","promise","res","resType","JsonStreamStringify","replacer","spaces","cycle","gap","spaceType","Number","isFinite","repeat","assign","visited","WeakMap","WeakSet","stack","replacerFunction","Function","replacerArray","depth","addToStack","key","existingPath","get","$ref","path","undefined","push","map","isInteger","v","set","length","join","index","realValue","toJSON","includes","type","_push","cycler","has","Error","add","open","obj","unread","keys","isEmpty","from","startsWith","ended","emit","flowing","pause","readCount","end","__read","err","error","first","unshift","item","isObject","delete","addSeparatorAfterEnd","splice","indexOf","data","pushCalled","current","removeFromStack","shift","processObject","String","out","isRunning","readMore","processStackTopItem","readAgain","setImmediate","catch","filter","reverse","Readable"],"mappings":";;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;EAEA,IAAMA,cAAc,iIAApB;;EAGA,IAAMC,OAAO;EACX,QAAM,KADK;EAEX,QAAM,KAFK;EAGX,QAAM,KAHK;EAIX,QAAM,KAJK;EAKX,QAAM,KALK;EAMX,OAAK,KANM;EAOX,QAAM;EAPK,CAAb;;EAUA,SAASC,gBAAT,CAA0BC,KAA1B,EAAiC;EAC/B,SAAO,OAAOA,MAAMC,IAAb,KAAsB,UAAtB,IACE,OAAOD,MAAME,IAAb,KAAsB,UADxB,IAEE,OAAOF,MAAMG,cAAb,KAAgC,UAFlC,IAGE,QAAOH,MAAMI,cAAb,MAAgC,QAHzC;EAID;;EAED,SAASC,OAAT,CAAiBL,KAAjB,EAAwB;EACtB,MAAI,CAACA,KAAL,EAAY,OAAO,WAAP;EACZ,MAAI,OAAOA,MAAMM,IAAb,KAAsB,UAA1B,EAAsC,OAAO,SAAP;EACtC,MAAIP,iBAAiBC,KAAjB,CAAJ,EAA6B,yBAAkBA,MAAMI,cAAN,CAAqBG,UAArB,GAAkC,QAAlC,GAA6C,QAA/D;EAC7B,MAAIC,MAAMC,OAAN,CAAcT,KAAd,CAAJ,EAA0B,OAAO,OAAP;EAC1B,MAAI,QAAOA,KAAP,MAAiB,QAAjB,IAA6BA,iBAAiBU,MAAlD,EAA0D,OAAO,QAAP;EAC1D,SAAO,WAAP;EACD;;EAED,IAAMC,eAAe;EACnBH,SAAO,GADY;EAEnBE,UAAQ,GAFW;EAGnBE,kBAAgB,GAHG;EAInBC,kBAAgB;EAJG,CAArB;EAOA,IAAMC,gBAAgB;EACpBN,SAAO,GADa;EAEpBE,UAAQ,GAFY;EAGpBE,kBAAgB,GAHI;EAIpBC,kBAAgB;EAJI,CAAtB;;EAOA,SAASE,YAAT,CAAsBC,MAAtB,EAA8B;EAC5B;EACA;EAEA;EACA;EACA;EACA;EAEA,SAAOA,OAAOC,OAAP,CAAepB,WAAf,EAA4B,UAACqB,CAAD,EAAO;EACxC,QAAMC,IAAIrB,KAAKoB,CAAL,CAAV;EACA,WAAO,OAAOC,CAAP,KAAa,QAAb,GAAwBA,CAAxB,gBAAkCD,EAAEE,UAAF,CAAa,CAAb,EAAgBC,QAAhB,CAAyB,EAAzB,EAA6BC,QAA7B,CAAsC,CAAtC,EAAyC,GAAzC,CAAlC,CAAP;EACD,GAHM,CAAP;EAID;;EAED,SAASC,WAAT,CAAqBP,MAArB,EAA6B;EAC3B,qBAAWD,aAAaC,MAAb,CAAX;EACD;;EAED,SAASQ,cAAT,CAAwBC,SAAxB,EAAgCC,IAAhC,EAAsC;EACpC,MAAM1B,QAAQyB,UAAOxB,IAAP,CAAYyB,IAAZ,CAAd;;EACA,MAAI1B,UAAU,IAAd,EAAoB;EAClB,WAAO,IAAI2B,OAAJ,CAAY,UAACC,OAAD,EAAUC,MAAV,EAAqB;EACtC,UAAMC,cAAc,SAAdA,WAAc;EAAA,eAAMF,QAAQ,IAAR,CAAN;EAAA,OAApB;;EACAH,gBAAOvB,IAAP,CAAY,KAAZ,EAAmB4B,WAAnB;EACAL,gBAAOvB,IAAP,CAAY,OAAZ,EAAqB2B,MAArB;EACAJ,gBAAOvB,IAAP,CAAY,UAAZ,EAAwB,YAAM;EAC5BuB,kBAAOtB,cAAP,CAAsB,KAAtB,EAA6B2B,WAA7B;EACAL,kBAAOtB,cAAP,CAAsB,OAAtB,EAA+B0B,MAA/B;EACAD,gBAAQH,UAAOxB,IAAP,EAAR;EACD,OAJD;EAKD,KATM,CAAP;EAUD;;EACD,SAAO0B,QAAQC,OAAR,CAAgB5B,KAAhB,CAAP;EACD;;EAED,SAAS+B,gBAAT,CAA0BC,OAA1B,EAAmC;EACjC,SAAOA,QAAQ1B,IAAR,CAAa,UAAC2B,GAAD,EAAS;EAC3B,QAAMC,UAAU7B,QAAQ4B,GAAR,CAAhB;EACA,WAAOC,YAAY,SAAZ,GAAwBH,iBAAiBE,GAAjB,CAAxB,GAAgDA,GAAvD;EACD,GAHM,CAAP;EAID;;MAEKE;;;;;EACJ,+BAAYnC,KAAZ,EAAmBoC,QAAnB,EAA6BC,MAA7B,EAAqCC,KAArC,EAA4C;EAAA;;EAAA;;EAC1C,6FAAM,EAAN;EACA,QAAIC,GAAJ;;EACA,QAAMC,oBAAmBH,MAAnB,CAAN;;EACA,QAAIG,cAAc,QAAd,IAA0BA,cAAc,QAA5C,EAAsD;EACpDD,YAAME,OAAOC,QAAP,CAAgBL,MAAhB,IAA0B,IAAIM,MAAJ,CAAWN,MAAX,CAA1B,GAA+CA,MAArD;EACD;;EACD3B,WAAOkC,MAAP,wDAAoB;EAClBC,eAASP,QAAQ,IAAIQ,OAAJ,EAAR,GAAwB,IAAIC,OAAJ,EADf;EAElBT,kBAFkB;EAGlBU,aAAO,EAHW;EAIlBC,wBAAkBb,oBAAoBc,QAApB,IAAgCd,QAJhC;EAKlBe,qBAAe3C,MAAMC,OAAN,CAAc2B,QAAd,KAA2BA,QALxB;EAMlBG,cANkB;EAOlBa,aAAO;EAPW,KAApB;;EASA,UAAKC,UAAL,CAAgBrD,KAAhB;;EAhB0C;EAiB3C;;;;6BAEMsD,KAAKtD,OAAO;EACjB,UAAMuD,eAAe,KAAKV,OAAL,CAAaW,GAAb,CAAiBxD,KAAjB,CAArB;;EACA,UAAIuD,YAAJ,EAAkB;EAChB,eAAO;EACLE,gBAAMF;EADD,SAAP;EAGD;;EACD,UAAIG,OAAO,KAAKA,IAAL,EAAX;EACA,UAAIJ,QAAQK,SAAZ,EAAuBD,KAAKE,IAAL,CAAUN,GAAV;EACvBI,aAAOA,KAAKG,GAAL,CAAS;EAAA,0BAAUpB,OAAOqB,SAAP,CAAiBC,CAAjB,IAAsBA,CAAtB,GAA0BxC,YAAYwC,CAAZ,CAApC;EAAA,OAAT,CAAP;EACA,WAAKlB,OAAL,CAAamB,GAAb,CAAiBhE,KAAjB,EAAwB0D,KAAKO,MAAL,cAAkBP,KAAKQ,IAAL,CAAU,EAAV,CAAlB,IAAoC,GAA5D;EACA,aAAOlE,KAAP;EACD;;;iCAEUA,OAAOsD,KAAKa,OAAO;EAAA;;EAC5B,UAAIC,YAAYpE,KAAhB;;EACA,UAAI,KAAKiD,gBAAT,EAA2B;EACzBmB,oBAAY,KAAKnB,gBAAL,CAAsBK,OAAOa,KAA7B,EAAoCC,SAApC,EAA+C,IAA/C,CAAZ;EACD,OAJ2B;;;EAM5B,UAAIA,aAAaA,UAAUC,MAAV,YAA4BnB,QAA7C,EAAuD;EACrDkB,oBAAYA,UAAUC,MAAV,EAAZ;EACD;;EACD,UAAID,qBAAqBlB,QAArB,IAAiC,QAAOlD,KAAP,MAAiB,QAAtD,EAAgE;EAC9DoE,oBAAYT,SAAZ;EACD;;EACD,UAAIL,QAAQK,SAAR,IAAqB,KAAKR,aAA9B,EAA6C;EAC3C,YAAI,CAAC,KAAKA,aAAL,CAAmBmB,QAAnB,CAA4BhB,GAA5B,CAAL,EAAuC;EACrCc,sBAAYT,SAAZ;EACD;EACF;;EACD,UAAIY,OAAOlE,QAAQ+D,SAAR,CAAX;;EACA,UAAIA,cAAcT,SAAd,IAA2BY,SAAS,SAApC,IAAiDjB,GAArD,EAA0D;EACxD,YAAI,KAAKf,GAAT,EAAc;EACZ,eAAKiC,KAAL,aAAgB,KAAKjC,GAAL,CAASI,MAAT,CAAgB,KAAKS,KAArB,CAAhB,eAA+CrC,aAAauC,GAAb,CAA/C;EACD,SAFD,MAEO;EACL,eAAKkB,KAAL,aAAezD,aAAauC,GAAb,CAAf;EACD;EACF;;EACD,UAAIiB,SAAS,WAAb,EAA0B;EACxB,YAAI,KAAKjC,KAAT,EAAgB;EACd;EACA8B,sBAAY,KAAKK,MAAL,CAAYnB,OAAOa,KAAnB,EAA0BC,SAA1B,CAAZ;EACAG,iBAAOlE,QAAQ+D,SAAR,CAAP;EACD,SAJD,MAIO;EACL;EACA,cAAI,KAAKvB,OAAL,CAAa6B,GAAb,CAAiBN,SAAjB,CAAJ,EAAiC;EAC/B,kBAAM1D,OAAOkC,MAAP,CAAc,IAAI+B,KAAJ,CAAU,uCAAV,CAAd,EAAkE;EACtEP,kCADsE;EAEtEd,mBAAKA,OAAOa;EAF0D,aAAlE,CAAN;EAID;;EACD,eAAKtB,OAAL,CAAa+B,GAAb,CAAiBR,SAAjB;EACD;EACF;;EAED,UAAI,CAACd,GAAD,IAAQa,QAAQ,CAAC,CAAjB,IAAsB,KAAKf,KAA3B,IAAoC,KAAKb,GAA7C,EAAkD,KAAKiC,KAAL,aAAgB,KAAKjC,GAAL,CAASI,MAAT,CAAgB,KAAKS,KAArB,CAAhB;EAElD,UAAMyB,OAAO/D,cAAcyD,IAAd,CAAb;EACA,UAAIM,IAAJ,EAAU,KAAKL,KAAL,CAAWK,IAAX;EAEV,UAAMC,MAAM;EACVxB,gBADU;EAEVa,oBAFU;EAGVI,kBAHU;EAIVvE,eAAOoE;EAJG,OAAZ;;EAOA,UAAIG,SAAS,QAAb,EAAuB;EACrB,aAAKnB,KAAL,IAAc,CAAd;EACA0B,YAAIC,MAAJ,GAAarE,OAAOsE,IAAP,CAAYZ,SAAZ,CAAb;EACAU,YAAIG,OAAJ,GAAc,CAACH,IAAIC,MAAJ,CAAWd,MAA1B;EACD,OAJD,MAIO,IAAIM,SAAS,OAAb,EAAsB;EAC3B,aAAKnB,KAAL,IAAc,CAAd;EACA0B,YAAIC,MAAJ,GAAavE,MAAM0E,IAAN,CAAW1E,MAAM4D,UAAUH,MAAhB,EAAwBe,IAAxB,EAAX,CAAb;EACAF,YAAIG,OAAJ,GAAc,CAACH,IAAIC,MAAJ,CAAWd,MAA1B;EACD,OAJM,MAIA,IAAIM,KAAKY,UAAL,CAAgB,UAAhB,CAAJ,EAAiC;EACtC,aAAK/B,KAAL,IAAc,CAAd;;EACA,YAAIgB,UAAUhE,cAAV,CAAyBgF,KAA7B,EAAoC;EAClC,eAAKC,IAAL,CAAU,OAAV,EAAmB,IAAIV,KAAJ,CAAU,oFAAV,CAAnB,EAAoHP,SAApH,EAA+Hd,OAAOa,KAAtI;EACD,SAFD,MAEO,IAAIC,UAAUhE,cAAV,CAAyBkF,OAA7B,EAAsC;EAC3ClB,oBAAUmB,KAAV;EACA,eAAKF,IAAL,CAAU,OAAV,EAAmB,IAAIV,KAAJ,CAAU,sFAAV,CAAnB,EAAsHP,SAAtH,EAAiId,OAAOa,KAAxI;EACD;;EACDW,YAAIU,SAAJ,GAAgB,CAAhB;EACApB,kBAAUlE,IAAV,CAAe,KAAf,EAAsB,YAAM;EAC1B4E,cAAIW,GAAJ,GAAU,IAAV;;EACA,iBAAKC,MAAL;EACD,SAHD;EAIAtB,kBAAUlE,IAAV,CAAe,OAAf,EAAwB,UAACyF,GAAD,EAAS;EAC/B,iBAAKC,KAAL,GAAa,IAAb;;EACA,iBAAKP,IAAL,CAAU,OAAV,EAAmBM,GAAnB;EACD,SAHD;EAIAb,YAAIe,KAAJ,GAAY,IAAZ;EACD;;EACD,WAAK7C,KAAL,CAAW8C,OAAX,CAAmBhB,GAAnB;EACA,aAAOA,GAAP;EACD;;;sCAEeiB,MAAM;EAAA,UAElBxB,IAFkB,GAGhBwB,IAHgB,CAElBxB,IAFkB;EAIpB,UAAMyB,WAAWzB,SAAS,QAAT,IAAqBA,SAAS,OAA9B,IAAyCA,KAAKY,UAAL,CAAgB,UAAhB,CAA1D;;EACA,UAAIZ,SAAS,WAAb,EAA0B;EACxB,YAAI,CAAC,KAAKjC,KAAV,EAAiB;EACf,eAAKO,OAAL,CAAaoD,MAAb,CAAoBF,KAAK/F,KAAzB;EACD;;EACD,YAAIgG,QAAJ,EAAc;EACZ,eAAK5C,KAAL,IAAc,CAAd;EACD;EACF;;EAED,UAAMqC,MAAM9E,aAAa4D,IAAb,CAAZ;EACA,UAAIyB,YAAY,CAACD,KAAKd,OAAlB,IAA6B,KAAK1C,GAAtC,EAA2C,KAAKiC,KAAL,aAAgB,KAAKjC,GAAL,CAASI,MAAT,CAAgB,KAAKS,KAArB,CAAhB;EAC3C,UAAIqC,GAAJ,EAAS,KAAKjB,KAAL,CAAWiB,GAAX;;EACT,UAAIM,KAAKG,oBAAT,EAA+B;EAC7B,aAAK1B,KAAL,CAAW,GAAX;EACD;;EACD,WAAKxB,KAAL,CAAWmD,MAAX,CAAkB,KAAKnD,KAAL,CAAWoD,OAAX,CAAmBL,IAAnB,CAAlB,EAA4C,CAA5C;EACD;;;4BAEKM,MAAM;EACV,WAAKC,UAAL,GAAkB,IAAlB;EACA,WAAK1C,IAAL,CAAUyC,IAAV;EACD;;;4CAEqBE,SAAS7E,MAAM;EAAA;;EACnC,UAAI6E,QAAQd,GAAZ,EAAiB;EACf,aAAKe,eAAL,CAAqBD,OAArB;EACA,eAAO5C,SAAP;EACD;;EACD,aAAOnC,eAAe+E,QAAQvG,KAAvB,EAA8B0B,IAA9B,EACJpB,IADI,CACC,UAACN,KAAD,EAAW;EACf,YAAIA,UAAU,IAAd,EAAoB;EAClB,cAAI,CAACuG,QAAQV,KAAb,EAAoB;EAClB,mBAAKrB,KAAL,CAAW,GAAX;EACD;EACD;;;EACA+B,kBAAQV,KAAR,GAAgB,KAAhB;;EACA,iBAAKxC,UAAL,CAAgBrD,KAAhB,EAAuB2D,SAAvB,EAAkC4C,QAAQf,SAA1C;;EACAe,kBAAQf,SAAR,IAAqB,CAArB;EACA;EACD;EACF,OAZI,CAAP;EAaD;;;oCAEae,SAAS;EACrB,UAAI,CAACA,QAAQxB,MAAR,CAAed,MAApB,EAA4B;EAC1B,aAAKuC,eAAL,CAAqBD,OAArB;EACA;EACD;;EACD,UAAMjD,MAAMiD,QAAQxB,MAAR,CAAe0B,KAAf,EAAZ;EACA,UAAMzG,QAAQuG,QAAQvG,KAAR,CAAcsD,GAAd,CAAd;EAEA,WAAKD,UAAL,CAAgBrD,KAAhB,EAAuBuG,QAAQhC,IAAR,KAAiB,QAAjB,IAA6BjB,GAApD,EAAyDiD,QAAQhC,IAAR,KAAiB,OAAjB,IAA4BjB,GAArF,EAA0F4C,oBAA1F,GAAiH,CAAC,CAACK,QAAQxB,MAAR,CAAed,MAAlI;EACD;;;mCAEYsC,SAAS;EACpB,aAAO,KAAKG,aAAL,CAAmBH,OAAnB,CAAP;EACD;;;uCAEgBA,SAAS;EACxB,UAAIA,QAAQvG,KAAR,KAAkB2D,SAAtB,EAAiC;EAC/B,YAAMY,eAAcgC,QAAQvG,KAAtB,CAAN;;EACA,YAAIA,KAAJ;;EACA,gBAAQuE,IAAR;EACA,eAAK,QAAL;EACEvE,oBAAQuB,YAAYgF,QAAQvG,KAApB,CAAR;EACA;;EACF,eAAK,QAAL;EACEA,oBAAQyC,OAAOC,QAAP,CAAgB6D,QAAQvG,KAAxB,IAAiC2G,OAAOJ,QAAQvG,KAAf,CAAjC,GAAyD,MAAjE;EACA;;EACF,eAAK,SAAL;EACA,eAAK,MAAL;EACEA,oBAAQ2G,OAAOJ,QAAQvG,KAAf,CAAR;EACA;;EACF,eAAK,QAAL;EACE,gBAAI,CAACuG,QAAQvG,KAAb,EAAoB;EAClBA,sBAAQ,MAAR;EACA;EACD;;EACD;;EACF;EACE;EACA;EACA,kBAAMU,OAAOkC,MAAP,CAAc,IAAI+B,KAAJ,0BAA2BJ,IAA3B,+BAAd,EAA0E;EAC9EvE,qBAAOuG,QAAQvG;EAD+D,aAA1E,CAAN;EApBF;;EAwBA,aAAKwE,KAAL,CAAWxE,KAAX;EACD,OA5BD,MA4BO,IAAI,KAAKgD,KAAL,CAAW,CAAX,MAAkB,KAAKA,KAAL,CAAW,CAAX,EAAcuB,IAAd,KAAuB,OAAvB,IAAkC,KAAKvB,KAAL,CAAW,CAAX,EAAcuB,IAAd,KAAuB,gBAA3E,CAAJ,EAAkG;EACvG,aAAKC,KAAL,CAAW,MAAX;EACD,OAFM,MAEA;EACL;EACA+B,gBAAQL,oBAAR,GAA+B,KAA/B;EACD;;EACD,WAAKM,eAAL,CAAqBD,OAArB;EACD;;;4CAEqBA,SAAS7E,MAAM;EAAA;;EACnC,UAAI6E,QAAQd,GAAZ,EAAiB;EACf,aAAKe,eAAL,CAAqBD,OAArB;EACA,eAAO5C,SAAP;EACD;;EACD,aAAOnC,eAAe+E,QAAQvG,KAAvB,EAA8B0B,IAA9B,EACJpB,IADI,CACC,UAACN,KAAD,EAAW;EACf,YAAIA,KAAJ,EAAW,OAAKwE,KAAL,CAAWzD,aAAaf,MAAMqB,QAAN,EAAb,CAAX;EACZ,OAHI,CAAP;EAID;;;qCAEckF,SAAS;EAAA;;EACtB,aAAOxE,iBAAiBwE,QAAQvG,KAAzB,EAAgCM,IAAhC,CAAqC,UAACN,KAAD,EAAW;EAAA,YAEnDkG,oBAFmD,GAGjDK,OAHiD,CAEnDL,oBAFmD;EAIrD;;EACAK,gBAAQL,oBAAR,GAA+B,KAA/B;;EACA,eAAKM,eAAL,CAAqBD,OAArB;;EACA,eAAKlD,UAAL,CAAgBrD,KAAhB,EAAuBuG,QAAQjD,GAA/B,EAAoCiD,QAAQpC,KAA5C,EACG+B,oBADH,GAC0BA,oBAD1B;EAED,OATM,CAAP;EAUD;;;0CAEmBxE,MAAM;EAAA;;EACxB,UAAM6E,UAAU,KAAKvD,KAAL,CAAW,CAAX,CAAhB;EACA,UAAI,CAACuD,OAAD,IAAY,KAAKX,KAArB,EAA4B,OAAOjE,QAAQC,OAAR,EAAP;EAC5B,UAAIgF,GAAJ;;EACA,UAAI;EACFA,cAAM,sBAAeL,QAAQhC,IAAvB,GAA+BgC,OAA/B,EAAwC7E,IAAxC,CAAN;EACD,OAFD,CAEE,OAAOiE,GAAP,EAAY;EACZ,eAAOhE,QAAQE,MAAR,CAAe8D,GAAf,CAAP;EACD;;EACD,aAAOhE,QAAQC,OAAR,CAAgBgF,GAAhB,EACJtG,IADI,CACC,YAAM;EACV,YAAI,OAAK0C,KAAL,CAAWiB,MAAX,KAAsB,CAA1B,EAA6B;EAC3B,iBAAKwB,GAAL,GAAW,IAAX;;EACA,iBAAKjB,KAAL,CAAW,IAAX;EACD;EACF,OANI,CAAP;EAOD;;;6BAEM9C,MAAM;EAAA;;EACX,UAAI,KAAKmF,SAAL,IAAkB,KAAKjB,KAA3B,EAAkC;EAChC,aAAKkB,QAAL,GAAgB,IAAhB;EACA,eAAOnD,SAAP;EACD;;EACD,WAAKkD,SAAL,GAAiB,IAAjB,CALW;;EAQX,WAAKC,QAAL,GAAgB,KAAhB;EACA,aAAO,KAAKC,mBAAL,CAAyBrF,IAAzB,EACJpB,IADI,CACC,YAAM;EACV,YAAM0G,YAAY,CAAC,OAAKvB,GAAN,IAAa,CAAC,OAAKG,KAAnB,KAA6B,OAAKkB,QAAL,IAAiB,CAAC,OAAKR,UAApD,CAAlB;;EACA,YAAIU,SAAJ,EAAe;EACbC,uBAAa,YAAM;EACjB,mBAAKJ,SAAL,GAAiB,KAAjB;;EACA,mBAAKnB,MAAL;EACD,WAHD;EAID,SALD,MAKO;EACL,iBAAKmB,SAAL,GAAiB,KAAjB;EACD;EACF,OAXI,EAYJK,KAZI,CAYE,UAACvB,GAAD,EAAS;EACd,eAAKC,KAAL,GAAa,IAAb;;EACA,eAAKP,IAAL,CAAU,OAAV,EAAmBM,GAAnB;EACD,OAfI,CAAP;EAgBD;;;4BAEKjE,MAAM;EACV,WAAK4E,UAAL,GAAkB,KAAlB;;EACA,WAAKZ,MAAL,CAAYhE,IAAZ;EACD;;;6BAEM;EACL,aAAO,KAAKsB,KAAL,CAAWa,GAAX,CAAe;EAAA,YACpBP,GADoB,QACpBA,GADoB;EAAA,YAEpBa,KAFoB,QAEpBA,KAFoB;EAAA,eAGhBb,OAAOa,KAHS;EAAA,OAAf,EAGagD,MAHb,CAGoB;EAAA,eAAKpD,KAAKA,IAAI,CAAC,CAAf;EAAA,OAHpB,EAGsCqD,OAHtC,EAAP;EAID;;;;IA3S+BC;;;;;;;;"} |
+570
| (function (global, factory) { | ||
| typeof exports === 'object' && typeof module !== 'undefined' ? module.exports = factory(require('core-js/modules/es6.array.filter'), require('@babel/runtime/core-js/set-immediate'), require('core-js/modules/es6.array.index-of'), require('core-js/modules/es6.string.starts-with'), require('core-js/modules/web.dom.iterable'), require('core-js/modules/es6.array.iterator'), require('@babel/runtime/core-js/array/from'), require('@babel/runtime/core-js/object/keys'), require('core-js/modules/es7.array.includes'), require('core-js/modules/es6.string.includes'), require('core-js/modules/es6.date.to-json'), require('@babel/runtime/core-js/number/is-integer'), require('core-js/modules/es6.array.map'), require('@babel/runtime/core-js/weak-set'), require('@babel/runtime/core-js/weak-map'), require('@babel/runtime/core-js/object/assign'), require('core-js/modules/es6.string.repeat'), require('@babel/runtime/core-js/number/is-finite'), require('@babel/runtime/core-js/promise'), require('core-js/modules/es6.regexp.to-string'), require('core-js/modules/es6.date.to-string'), require('core-js/modules/es7.string.pad-start'), require('core-js/modules/es6.regexp.replace'), require('core-js/modules/es6.array.is-array'), require('stream')) : | ||
| typeof define === 'function' && define.amd ? define(['core-js/modules/es6.array.filter', '@babel/runtime/core-js/set-immediate', 'core-js/modules/es6.array.index-of', 'core-js/modules/es6.string.starts-with', 'core-js/modules/web.dom.iterable', 'core-js/modules/es6.array.iterator', '@babel/runtime/core-js/array/from', '@babel/runtime/core-js/object/keys', 'core-js/modules/es7.array.includes', 'core-js/modules/es6.string.includes', 'core-js/modules/es6.date.to-json', '@babel/runtime/core-js/number/is-integer', 'core-js/modules/es6.array.map', '@babel/runtime/core-js/weak-set', '@babel/runtime/core-js/weak-map', '@babel/runtime/core-js/object/assign', 'core-js/modules/es6.string.repeat', '@babel/runtime/core-js/number/is-finite', '@babel/runtime/core-js/promise', 'core-js/modules/es6.regexp.to-string', 'core-js/modules/es6.date.to-string', 'core-js/modules/es7.string.pad-start', 'core-js/modules/es6.regexp.replace', 'core-js/modules/es6.array.is-array', 'stream'], factory) : | ||
| (global.jsonStreamStringify = factory(null,null,null,null,null,null,null,null,null,null,null,null,null,null,null,null,null,null,null,null,null,null,null,null,global.stream)); | ||
| }(this, (function (es6_array_filter,_setImmediate,es6_array_indexOf,es6_string_startsWith,web_dom_iterable,es6_array_iterator,_Array$from,_Object$keys,es7_array_includes,es6_string_includes,es6_date_toJson,_Number$isInteger,es6_array_map,_WeakSet,_WeakMap,_Object$assign,es6_string_repeat,_Number$isFinite,_Promise,es6_regexp_toString,es6_date_toString,es7_string_padStart,es6_regexp_replace,es6_array_isArray,stream) { 'use strict'; | ||
| _setImmediate = _setImmediate && _setImmediate.hasOwnProperty('default') ? _setImmediate['default'] : _setImmediate; | ||
| _Array$from = _Array$from && _Array$from.hasOwnProperty('default') ? _Array$from['default'] : _Array$from; | ||
| _Object$keys = _Object$keys && _Object$keys.hasOwnProperty('default') ? _Object$keys['default'] : _Object$keys; | ||
| _Number$isInteger = _Number$isInteger && _Number$isInteger.hasOwnProperty('default') ? _Number$isInteger['default'] : _Number$isInteger; | ||
| _WeakSet = _WeakSet && _WeakSet.hasOwnProperty('default') ? _WeakSet['default'] : _WeakSet; | ||
| _WeakMap = _WeakMap && _WeakMap.hasOwnProperty('default') ? _WeakMap['default'] : _WeakMap; | ||
| _Object$assign = _Object$assign && _Object$assign.hasOwnProperty('default') ? _Object$assign['default'] : _Object$assign; | ||
| _Number$isFinite = _Number$isFinite && _Number$isFinite.hasOwnProperty('default') ? _Number$isFinite['default'] : _Number$isFinite; | ||
| _Promise = _Promise && _Promise.hasOwnProperty('default') ? _Promise['default'] : _Promise; | ||
| 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 _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 _inherits(subClass, superClass) { | ||
| if (typeof superClass !== "function" && superClass !== null) { | ||
| throw new TypeError("Super expression must either be null or a function"); | ||
| } | ||
| subClass.prototype = Object.create(superClass && superClass.prototype, { | ||
| constructor: { | ||
| value: subClass, | ||
| writable: true, | ||
| configurable: true | ||
| } | ||
| }); | ||
| if (superClass) _setPrototypeOf(subClass, superClass); | ||
| } | ||
| function _getPrototypeOf(o) { | ||
| _getPrototypeOf = Object.setPrototypeOf ? Object.getPrototypeOf : function _getPrototypeOf(o) { | ||
| return o.__proto__ || Object.getPrototypeOf(o); | ||
| }; | ||
| return _getPrototypeOf(o); | ||
| } | ||
| function _setPrototypeOf(o, p) { | ||
| _setPrototypeOf = Object.setPrototypeOf || function _setPrototypeOf(o, p) { | ||
| o.__proto__ = p; | ||
| return o; | ||
| }; | ||
| return _setPrototypeOf(o, p); | ||
| } | ||
| function _assertThisInitialized(self) { | ||
| if (self === void 0) { | ||
| throw new ReferenceError("this hasn't been initialised - super() hasn't been called"); | ||
| } | ||
| return self; | ||
| } | ||
| function _possibleConstructorReturn(self, call) { | ||
| if (call && (typeof call === "object" || typeof call === "function")) { | ||
| return call; | ||
| } | ||
| return _assertThisInitialized(self); | ||
| } | ||
| var rxEscapable = /[\\"\u0000-\u001f\u007f-\u009f\u00ad\u0600-\u0604\u070f\u17b4\u17b5\u200c-\u200f\u2028-\u202f\u2060-\u206f\ufeff\ufff0-\uffff]/g; // table of character substitutions | ||
| var meta = { | ||
| '\b': '\\b', | ||
| '\t': '\\t', | ||
| '\n': '\\n', | ||
| '\f': '\\f', | ||
| '\r': '\\r', | ||
| '"': '\\"', | ||
| '\\': '\\\\' | ||
| }; | ||
| function isReadableStream(value) { | ||
| return typeof value.read === 'function' && typeof value.once === 'function' && typeof value.removeListener === 'function' && _typeof(value._readableState) === 'object'; | ||
| } | ||
| function getType(value) { | ||
| if (!value) return 'Primitive'; | ||
| if (typeof value.then === 'function') return 'Promise'; | ||
| if (isReadableStream(value)) return "Readable".concat(value._readableState.objectMode ? 'Object' : 'String'); | ||
| if (Array.isArray(value)) return 'Array'; | ||
| if (_typeof(value) === 'object' || value instanceof Object) return 'Object'; | ||
| return 'Primitive'; | ||
| } | ||
| var stackItemEnd = { | ||
| Array: ']', | ||
| Object: '}', | ||
| ReadableString: '"', | ||
| ReadableObject: ']' | ||
| }; | ||
| var stackItemOpen = { | ||
| Array: '[', | ||
| Object: '{', | ||
| ReadableString: '"', | ||
| ReadableObject: '[' | ||
| }; | ||
| function escapeString(string) { | ||
| // Modified code, original code by Douglas Crockford | ||
| // Original: https://github.com/douglascrockford/JSON-js/blob/master/json2.js | ||
| // If the string contains no control characters, no quote characters, and no | ||
| // backslash characters, then we can safely slap some quotes around it. | ||
| // Otherwise we must also replace the offending characters with safe escape | ||
| // sequences. | ||
| return string.replace(rxEscapable, function (a) { | ||
| var c = meta[a]; | ||
| return typeof c === 'string' ? c : "\\u".concat(a.charCodeAt(0).toString(16).padStart(4, '0')); | ||
| }); | ||
| } | ||
| function quoteString(string) { | ||
| return "\"".concat(escapeString(string), "\""); | ||
| } | ||
| function readAsPromised(stream$$1, size) { | ||
| var value = stream$$1.read(size); | ||
| if (value === null) { | ||
| return new _Promise(function (resolve, reject) { | ||
| var endListener = function endListener() { | ||
| return resolve(null); | ||
| }; | ||
| stream$$1.once('end', endListener); | ||
| stream$$1.once('error', reject); | ||
| stream$$1.once('readable', function () { | ||
| stream$$1.removeListener('end', endListener); | ||
| stream$$1.removeListener('error', reject); | ||
| resolve(stream$$1.read()); | ||
| }); | ||
| }); | ||
| } | ||
| return _Promise.resolve(value); | ||
| } | ||
| function recursiveResolve(promise) { | ||
| return promise.then(function (res) { | ||
| var resType = getType(res); | ||
| return resType === 'Promise' ? recursiveResolve(res) : res; | ||
| }); | ||
| } | ||
| var JsonStreamStringify = | ||
| /*#__PURE__*/ | ||
| function (_Readable) { | ||
| _inherits(JsonStreamStringify, _Readable); | ||
| function JsonStreamStringify(value, replacer, spaces, cycle) { | ||
| var _this; | ||
| _classCallCheck(this, JsonStreamStringify); | ||
| _this = _possibleConstructorReturn(this, _getPrototypeOf(JsonStreamStringify).call(this, {})); | ||
| var gap; | ||
| var spaceType = _typeof(spaces); | ||
| if (spaceType === 'string' || spaceType === 'number') { | ||
| gap = _Number$isFinite(spaces) ? ' '.repeat(spaces) : spaces; | ||
| } | ||
| _Object$assign(_assertThisInitialized(_assertThisInitialized(_this)), { | ||
| visited: cycle ? new _WeakMap() : new _WeakSet(), | ||
| cycle: cycle, | ||
| stack: [], | ||
| replacerFunction: replacer instanceof Function && replacer, | ||
| replacerArray: Array.isArray(replacer) && replacer, | ||
| gap: gap, | ||
| depth: 0 | ||
| }); | ||
| _this.addToStack(value); | ||
| return _this; | ||
| } | ||
| _createClass(JsonStreamStringify, [{ | ||
| key: "cycler", | ||
| value: function cycler(key, value) { | ||
| var existingPath = this.visited.get(value); | ||
| if (existingPath) { | ||
| return { | ||
| $ref: existingPath | ||
| }; | ||
| } | ||
| var path = this.path(); | ||
| if (key !== undefined) path.push(key); | ||
| path = path.map(function (v) { | ||
| return "[".concat(_Number$isInteger(v) ? v : quoteString(v), "]"); | ||
| }); | ||
| this.visited.set(value, path.length ? "$".concat(path.join('')) : '$'); | ||
| return value; | ||
| } | ||
| }, { | ||
| key: "addToStack", | ||
| value: function addToStack(value, key, index) { | ||
| var _this2 = this; | ||
| var realValue = value; | ||
| if (this.replacerFunction) { | ||
| realValue = this.replacerFunction(key || index, realValue, this); | ||
| } // ORDER? | ||
| if (realValue && realValue.toJSON instanceof Function) { | ||
| realValue = realValue.toJSON(); | ||
| } | ||
| if (realValue instanceof Function || _typeof(value) === 'symbol') { | ||
| realValue = undefined; | ||
| } | ||
| if (key !== undefined && this.replacerArray) { | ||
| if (!this.replacerArray.includes(key)) { | ||
| realValue = undefined; | ||
| } | ||
| } | ||
| var type = getType(realValue); | ||
| if (realValue !== undefined && type !== 'Promise' && key) { | ||
| if (this.gap) { | ||
| this._push("\n".concat(this.gap.repeat(this.depth), "\"").concat(escapeString(key), "\": ")); | ||
| } else { | ||
| this._push("\"".concat(escapeString(key), "\":")); | ||
| } | ||
| } | ||
| if (type !== 'Primitive') { | ||
| if (this.cycle) { | ||
| // run cycler | ||
| realValue = this.cycler(key || index, realValue); | ||
| type = getType(realValue); | ||
| } else { | ||
| // check for circular structure | ||
| if (this.visited.has(realValue)) { | ||
| throw _Object$assign(new Error('Converting circular structure to JSON'), { | ||
| realValue: realValue, | ||
| key: key || index | ||
| }); | ||
| } | ||
| this.visited.add(realValue); | ||
| } | ||
| } | ||
| if (!key && index > -1 && this.depth && this.gap) this._push("\n".concat(this.gap.repeat(this.depth))); | ||
| var open = stackItemOpen[type]; | ||
| if (open) this._push(open); | ||
| var obj = { | ||
| key: key, | ||
| index: index, | ||
| type: type, | ||
| value: realValue | ||
| }; | ||
| if (type === 'Object') { | ||
| this.depth += 1; | ||
| obj.unread = _Object$keys(realValue); | ||
| obj.isEmpty = !obj.unread.length; | ||
| } else if (type === 'Array') { | ||
| this.depth += 1; | ||
| obj.unread = _Array$from(Array(realValue.length).keys()); | ||
| obj.isEmpty = !obj.unread.length; | ||
| } else if (type.startsWith('Readable')) { | ||
| this.depth += 1; | ||
| if (realValue._readableState.ended) { | ||
| this.emit('error', new Error('Readable Stream has ended before it was serialized. All stream data have been lost'), realValue, key || index); | ||
| } else if (realValue._readableState.flowing) { | ||
| realValue.pause(); | ||
| this.emit('error', new Error('Readable Stream is in flowing mode, data may have been lost. Trying to pause stream.'), realValue, key || index); | ||
| } | ||
| obj.readCount = 0; | ||
| realValue.once('end', function () { | ||
| obj.end = true; | ||
| _this2.__read(); | ||
| }); | ||
| realValue.once('error', function (err) { | ||
| _this2.error = true; | ||
| _this2.emit('error', err); | ||
| }); | ||
| obj.first = true; | ||
| } | ||
| this.stack.unshift(obj); | ||
| return obj; | ||
| } | ||
| }, { | ||
| key: "removeFromStack", | ||
| value: function removeFromStack(item) { | ||
| var type = item.type; | ||
| var isObject = type === 'Object' || type === 'Array' || type.startsWith('Readable'); | ||
| if (type !== 'Primitive') { | ||
| if (!this.cycle) { | ||
| this.visited.delete(item.value); | ||
| } | ||
| if (isObject) { | ||
| this.depth -= 1; | ||
| } | ||
| } | ||
| var end = stackItemEnd[type]; | ||
| if (isObject && !item.isEmpty && this.gap) this._push("\n".concat(this.gap.repeat(this.depth))); | ||
| if (end) this._push(end); | ||
| if (item.addSeparatorAfterEnd) { | ||
| this._push(','); | ||
| } | ||
| this.stack.splice(this.stack.indexOf(item), 1); | ||
| } | ||
| }, { | ||
| key: "_push", | ||
| value: function _push(data) { | ||
| this.pushCalled = true; | ||
| this.push(data); | ||
| } | ||
| }, { | ||
| key: "processReadableObject", | ||
| value: function processReadableObject(current, size) { | ||
| var _this3 = this; | ||
| if (current.end) { | ||
| this.removeFromStack(current); | ||
| return undefined; | ||
| } | ||
| return readAsPromised(current.value, size).then(function (value) { | ||
| if (value !== null) { | ||
| if (!current.first) { | ||
| _this3._push(','); | ||
| } | ||
| /* eslint-disable no-param-reassign */ | ||
| current.first = false; | ||
| _this3.addToStack(value, undefined, current.readCount); | ||
| current.readCount += 1; | ||
| /* eslint-enable no-param-reassign */ | ||
| } | ||
| }); | ||
| } | ||
| }, { | ||
| key: "processObject", | ||
| value: function processObject(current) { | ||
| if (!current.unread.length) { | ||
| this.removeFromStack(current); | ||
| return; | ||
| } | ||
| var key = current.unread.shift(); | ||
| var value = current.value[key]; | ||
| this.addToStack(value, current.type === 'Object' && key, current.type === 'Array' && key).addSeparatorAfterEnd = !!current.unread.length; | ||
| } | ||
| }, { | ||
| key: "processArray", | ||
| value: function processArray(current) { | ||
| return this.processObject(current); | ||
| } | ||
| }, { | ||
| key: "processPrimitive", | ||
| value: function processPrimitive(current) { | ||
| if (current.value !== undefined) { | ||
| var type = _typeof(current.value); | ||
| var value; | ||
| switch (type) { | ||
| case 'string': | ||
| value = quoteString(current.value); | ||
| break; | ||
| case 'number': | ||
| value = _Number$isFinite(current.value) ? String(current.value) : 'null'; | ||
| break; | ||
| case 'boolean': | ||
| case 'null': | ||
| value = String(current.value); | ||
| break; | ||
| case 'object': | ||
| if (!current.value) { | ||
| value = 'null'; | ||
| break; | ||
| } | ||
| /* eslint-disable-next-line no-fallthrough */ | ||
| default: | ||
| // This should never happen, I can't imagine a situation where this executes. | ||
| // If you find a way, please open a ticket or PR | ||
| throw _Object$assign(new Error("Unknown type \"".concat(type, "\". Please file an issue!")), { | ||
| value: current.value | ||
| }); | ||
| } | ||
| this._push(value); | ||
| } else if (this.stack[1] && (this.stack[1].type === 'Array' || this.stack[1].type === 'ReadableObject')) { | ||
| this._push('null'); | ||
| } else { | ||
| /* eslint-disable-next-line no-param-reassign */ | ||
| current.addSeparatorAfterEnd = false; | ||
| } | ||
| this.removeFromStack(current); | ||
| } | ||
| }, { | ||
| key: "processReadableString", | ||
| value: function processReadableString(current, size) { | ||
| var _this4 = this; | ||
| if (current.end) { | ||
| this.removeFromStack(current); | ||
| return undefined; | ||
| } | ||
| return readAsPromised(current.value, size).then(function (value) { | ||
| if (value) _this4._push(escapeString(value.toString())); | ||
| }); | ||
| } | ||
| }, { | ||
| key: "processPromise", | ||
| value: function processPromise(current) { | ||
| var _this5 = this; | ||
| return recursiveResolve(current.value).then(function (value) { | ||
| var addSeparatorAfterEnd = current.addSeparatorAfterEnd; | ||
| /* eslint-disable-next-line no-param-reassign */ | ||
| current.addSeparatorAfterEnd = false; | ||
| _this5.removeFromStack(current); | ||
| _this5.addToStack(value, current.key, current.index).addSeparatorAfterEnd = addSeparatorAfterEnd; | ||
| }); | ||
| } | ||
| }, { | ||
| key: "processStackTopItem", | ||
| value: function processStackTopItem(size) { | ||
| var _this6 = this; | ||
| var current = this.stack[0]; | ||
| if (!current || this.error) return _Promise.resolve(); | ||
| var out; | ||
| try { | ||
| out = this["process".concat(current.type)](current, size); | ||
| } catch (err) { | ||
| return _Promise.reject(err); | ||
| } | ||
| return _Promise.resolve(out).then(function () { | ||
| if (_this6.stack.length === 0) { | ||
| _this6.end = true; | ||
| _this6._push(null); | ||
| } | ||
| }); | ||
| } | ||
| }, { | ||
| key: "__read", | ||
| value: function __read(size) { | ||
| var _this7 = this; | ||
| if (this.isRunning || this.error) { | ||
| this.readMore = true; | ||
| return undefined; | ||
| } | ||
| this.isRunning = true; // we must continue to read while push has not been called | ||
| this.readMore = false; | ||
| return this.processStackTopItem(size).then(function () { | ||
| var readAgain = !_this7.end && !_this7.error && (_this7.readMore || !_this7.pushCalled); | ||
| if (readAgain) { | ||
| _setImmediate(function () { | ||
| _this7.isRunning = false; | ||
| _this7.__read(); | ||
| }); | ||
| } else { | ||
| _this7.isRunning = false; | ||
| } | ||
| }).catch(function (err) { | ||
| _this7.error = true; | ||
| _this7.emit('error', err); | ||
| }); | ||
| } | ||
| }, { | ||
| key: "_read", | ||
| value: function _read(size) { | ||
| this.pushCalled = false; | ||
| this.__read(size); | ||
| } | ||
| }, { | ||
| key: "path", | ||
| value: function path() { | ||
| return this.stack.map(function (_ref) { | ||
| var key = _ref.key, | ||
| index = _ref.index; | ||
| return key || index; | ||
| }).filter(function (v) { | ||
| return v || v > -1; | ||
| }).reverse(); | ||
| } | ||
| }]); | ||
| return JsonStreamStringify; | ||
| }(stream.Readable); | ||
| return JsonStreamStringify; | ||
| }))); | ||
| //# sourceMappingURL=umd.polyfill.js.map |
| {"version":3,"file":"umd.polyfill.js","sources":["../src/JsonStreamStringify.js"],"sourcesContent":["import { Readable } from 'stream';\n\nconst rxEscapable = /[\\\\\"\\u0000-\\u001f\\u007f-\\u009f\\u00ad\\u0600-\\u0604\\u070f\\u17b4\\u17b5\\u200c-\\u200f\\u2028-\\u202f\\u2060-\\u206f\\ufeff\\ufff0-\\uffff]/g;\n\n// table of character substitutions\nconst meta = {\n '\\b': '\\\\b',\n '\\t': '\\\\t',\n '\\n': '\\\\n',\n '\\f': '\\\\f',\n '\\r': '\\\\r',\n '\"': '\\\\\"',\n '\\\\': '\\\\\\\\',\n};\n\nfunction isReadableStream(value) {\n return typeof value.read === 'function'\n && typeof value.once === 'function'\n && typeof value.removeListener === 'function'\n && typeof value._readableState === 'object';\n}\n\nfunction getType(value) {\n if (!value) return 'Primitive';\n if (typeof value.then === 'function') return 'Promise';\n if (isReadableStream(value)) return `Readable${value._readableState.objectMode ? 'Object' : 'String'}`;\n if (Array.isArray(value)) return 'Array';\n if (typeof value === 'object' || value instanceof Object) return 'Object';\n return 'Primitive';\n}\n\nconst stackItemEnd = {\n Array: ']',\n Object: '}',\n ReadableString: '\"',\n ReadableObject: ']',\n};\n\nconst stackItemOpen = {\n Array: '[',\n Object: '{',\n ReadableString: '\"',\n ReadableObject: '[',\n};\n\nfunction escapeString(string) {\n // Modified code, original code by Douglas Crockford\n // Original: https://github.com/douglascrockford/JSON-js/blob/master/json2.js\n\n // If the string contains no control characters, no quote characters, and no\n // backslash characters, then we can safely slap some quotes around it.\n // Otherwise we must also replace the offending characters with safe escape\n // sequences.\n\n return string.replace(rxEscapable, (a) => {\n const c = meta[a];\n return typeof c === 'string' ? c : `\\\\u${a.charCodeAt(0).toString(16).padStart(4, '0')}`;\n });\n}\n\nfunction quoteString(string) {\n return `\"${escapeString(string)}\"`;\n}\n\nfunction readAsPromised(stream, size) {\n const value = stream.read(size);\n if (value === null) {\n return new Promise((resolve, reject) => {\n const endListener = () => resolve(null);\n stream.once('end', endListener);\n stream.once('error', reject);\n stream.once('readable', () => {\n stream.removeListener('end', endListener);\n stream.removeListener('error', reject);\n resolve(stream.read());\n });\n });\n }\n return Promise.resolve(value);\n}\n\nfunction recursiveResolve(promise) {\n return promise.then((res) => {\n const resType = getType(res);\n return resType === 'Promise' ? recursiveResolve(res) : res;\n });\n}\n\nclass JsonStreamStringify extends Readable {\n constructor(value, replacer, spaces, cycle) {\n super({});\n let gap;\n const spaceType = typeof spaces;\n if (spaceType === 'string' || spaceType === 'number') {\n gap = Number.isFinite(spaces) ? ' '.repeat(spaces) : spaces;\n }\n Object.assign(this, {\n visited: cycle ? new WeakMap() : new WeakSet(),\n cycle,\n stack: [],\n replacerFunction: replacer instanceof Function && replacer,\n replacerArray: Array.isArray(replacer) && replacer,\n gap,\n depth: 0,\n });\n this.addToStack(value);\n }\n\n cycler(key, value) {\n const existingPath = this.visited.get(value);\n if (existingPath) {\n return {\n $ref: existingPath,\n };\n }\n let path = this.path();\n if (key !== undefined) path.push(key);\n path = path.map(v => `[${(Number.isInteger(v) ? v : quoteString(v))}]`);\n this.visited.set(value, path.length ? `$${path.join('')}` : '$');\n return value;\n }\n\n addToStack(value, key, index) {\n let realValue = value;\n if (this.replacerFunction) {\n realValue = this.replacerFunction(key || index, realValue, this);\n }\n // ORDER?\n if (realValue && realValue.toJSON instanceof Function) {\n realValue = realValue.toJSON();\n }\n if (realValue instanceof Function || typeof value === 'symbol') {\n realValue = undefined;\n }\n if (key !== undefined && this.replacerArray) {\n if (!this.replacerArray.includes(key)) {\n realValue = undefined;\n }\n }\n let type = getType(realValue);\n if (realValue !== undefined && type !== 'Promise' && key) {\n if (this.gap) {\n this._push(`\\n${this.gap.repeat(this.depth)}\"${escapeString(key)}\": `);\n } else {\n this._push(`\"${escapeString(key)}\":`);\n }\n }\n if (type !== 'Primitive') {\n if (this.cycle) {\n // run cycler\n realValue = this.cycler(key || index, realValue);\n type = getType(realValue);\n } else {\n // check for circular structure\n if (this.visited.has(realValue)) {\n throw Object.assign(new Error('Converting circular structure to JSON'), {\n realValue,\n key: key || index,\n });\n }\n this.visited.add(realValue);\n }\n }\n\n if (!key && index > -1 && this.depth && this.gap) this._push(`\\n${this.gap.repeat(this.depth)}`);\n\n const open = stackItemOpen[type];\n if (open) this._push(open);\n\n const obj = {\n key,\n index,\n type,\n value: realValue,\n };\n\n if (type === 'Object') {\n this.depth += 1;\n obj.unread = Object.keys(realValue);\n obj.isEmpty = !obj.unread.length;\n } else if (type === 'Array') {\n this.depth += 1;\n obj.unread = Array.from(Array(realValue.length).keys());\n obj.isEmpty = !obj.unread.length;\n } else if (type.startsWith('Readable')) {\n this.depth += 1;\n if (realValue._readableState.ended) {\n this.emit('error', new Error('Readable Stream has ended before it was serialized. All stream data have been lost'), realValue, key || index);\n } else if (realValue._readableState.flowing) {\n realValue.pause();\n this.emit('error', new Error('Readable Stream is in flowing mode, data may have been lost. Trying to pause stream.'), realValue, key || index);\n }\n obj.readCount = 0;\n realValue.once('end', () => {\n obj.end = true;\n this.__read();\n });\n realValue.once('error', (err) => {\n this.error = true;\n this.emit('error', err);\n });\n obj.first = true;\n }\n this.stack.unshift(obj);\n return obj;\n }\n\n removeFromStack(item) {\n const {\n type,\n } = item;\n const isObject = type === 'Object' || type === 'Array' || type.startsWith('Readable');\n if (type !== 'Primitive') {\n if (!this.cycle) {\n this.visited.delete(item.value);\n }\n if (isObject) {\n this.depth -= 1;\n }\n }\n\n const end = stackItemEnd[type];\n if (isObject && !item.isEmpty && this.gap) this._push(`\\n${this.gap.repeat(this.depth)}`);\n if (end) this._push(end);\n if (item.addSeparatorAfterEnd) {\n this._push(',');\n }\n this.stack.splice(this.stack.indexOf(item), 1);\n }\n\n _push(data) {\n this.pushCalled = true;\n this.push(data);\n }\n\n processReadableObject(current, size) {\n if (current.end) {\n this.removeFromStack(current);\n return undefined;\n }\n return readAsPromised(current.value, size)\n .then((value) => {\n if (value !== null) {\n if (!current.first) {\n this._push(',');\n }\n /* eslint-disable no-param-reassign */\n current.first = false;\n this.addToStack(value, undefined, current.readCount);\n current.readCount += 1;\n /* eslint-enable no-param-reassign */\n }\n });\n }\n\n processObject(current) {\n if (!current.unread.length) {\n this.removeFromStack(current);\n return;\n }\n const key = current.unread.shift();\n const value = current.value[key];\n\n this.addToStack(value, current.type === 'Object' && key, current.type === 'Array' && key).addSeparatorAfterEnd = !!current.unread.length;\n }\n\n processArray(current) {\n return this.processObject(current);\n }\n\n processPrimitive(current) {\n if (current.value !== undefined) {\n const type = typeof current.value;\n let value;\n switch (type) {\n case 'string':\n value = quoteString(current.value);\n break;\n case 'number':\n value = Number.isFinite(current.value) ? String(current.value) : 'null';\n break;\n case 'boolean':\n case 'null':\n value = String(current.value);\n break;\n case 'object':\n if (!current.value) {\n value = 'null';\n break;\n }\n /* eslint-disable-next-line no-fallthrough */\n default:\n // This should never happen, I can't imagine a situation where this executes.\n // If you find a way, please open a ticket or PR\n throw Object.assign(new Error(`Unknown type \"${type}\". Please file an issue!`), {\n value: current.value,\n });\n }\n this._push(value);\n } else if (this.stack[1] && (this.stack[1].type === 'Array' || this.stack[1].type === 'ReadableObject')) {\n this._push('null');\n } else {\n /* eslint-disable-next-line no-param-reassign */\n current.addSeparatorAfterEnd = false;\n }\n this.removeFromStack(current);\n }\n\n processReadableString(current, size) {\n if (current.end) {\n this.removeFromStack(current);\n return undefined;\n }\n return readAsPromised(current.value, size)\n .then((value) => {\n if (value) this._push(escapeString(value.toString()));\n });\n }\n\n processPromise(current) {\n return recursiveResolve(current.value).then((value) => {\n const {\n addSeparatorAfterEnd,\n } = current;\n /* eslint-disable-next-line no-param-reassign */\n current.addSeparatorAfterEnd = false;\n this.removeFromStack(current);\n this.addToStack(value, current.key, current.index)\n .addSeparatorAfterEnd = addSeparatorAfterEnd;\n });\n }\n\n processStackTopItem(size) {\n const current = this.stack[0];\n if (!current || this.error) return Promise.resolve();\n let out;\n try {\n out = this[`process${current.type}`](current, size);\n } catch (err) {\n return Promise.reject(err);\n }\n return Promise.resolve(out)\n .then(() => {\n if (this.stack.length === 0) {\n this.end = true;\n this._push(null);\n }\n });\n }\n\n __read(size) {\n if (this.isRunning || this.error) {\n this.readMore = true;\n return undefined;\n }\n this.isRunning = true;\n\n // we must continue to read while push has not been called\n this.readMore = false;\n return this.processStackTopItem(size)\n .then(() => {\n const readAgain = !this.end && !this.error && (this.readMore || !this.pushCalled);\n if (readAgain) {\n setImmediate(() => {\n this.isRunning = false;\n this.__read();\n });\n } else {\n this.isRunning = false;\n }\n })\n .catch((err) => {\n this.error = true;\n this.emit('error', err);\n });\n }\n\n _read(size) {\n this.pushCalled = false;\n this.__read(size);\n }\n\n path() {\n return this.stack.map(({\n key,\n index,\n }) => key || index).filter(v => v || v > -1).reverse();\n }\n}\n\nexport default JsonStreamStringify;\n"],"names":["rxEscapable","meta","isReadableStream","value","read","once","removeListener","_readableState","getType","then","objectMode","Array","isArray","Object","stackItemEnd","ReadableString","ReadableObject","stackItemOpen","escapeString","string","replace","a","c","charCodeAt","toString","padStart","quoteString","readAsPromised","stream","size","resolve","reject","endListener","recursiveResolve","promise","res","resType","JsonStreamStringify","replacer","spaces","cycle","gap","spaceType","repeat","visited","stack","replacerFunction","Function","replacerArray","depth","addToStack","key","existingPath","get","$ref","path","undefined","push","map","v","set","length","join","index","realValue","toJSON","includes","type","_push","cycler","has","Error","add","open","obj","unread","isEmpty","keys","startsWith","ended","emit","flowing","pause","readCount","end","__read","err","error","first","unshift","item","isObject","delete","addSeparatorAfterEnd","splice","indexOf","data","pushCalled","current","removeFromStack","shift","processObject","String","out","isRunning","readMore","processStackTopItem","readAgain","catch","filter","reverse","Readable"],"mappings":";;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;EAEA,IAAMA,cAAc,iIAApB;;EAGA,IAAMC,OAAO;EACX,QAAM,KADK;EAEX,QAAM,KAFK;EAGX,QAAM,KAHK;EAIX,QAAM,KAJK;EAKX,QAAM,KALK;EAMX,OAAK,KANM;EAOX,QAAM;EAPK,CAAb;;EAUA,SAASC,gBAAT,CAA0BC,KAA1B,EAAiC;EAC/B,SAAO,OAAOA,MAAMC,IAAb,KAAsB,UAAtB,IACE,OAAOD,MAAME,IAAb,KAAsB,UADxB,IAEE,OAAOF,MAAMG,cAAb,KAAgC,UAFlC,IAGE,QAAOH,MAAMI,cAAb,MAAgC,QAHzC;EAID;;EAED,SAASC,OAAT,CAAiBL,KAAjB,EAAwB;EACtB,MAAI,CAACA,KAAL,EAAY,OAAO,WAAP;EACZ,MAAI,OAAOA,MAAMM,IAAb,KAAsB,UAA1B,EAAsC,OAAO,SAAP;EACtC,MAAIP,iBAAiBC,KAAjB,CAAJ,EAA6B,yBAAkBA,MAAMI,cAAN,CAAqBG,UAArB,GAAkC,QAAlC,GAA6C,QAA/D;EAC7B,MAAIC,MAAMC,OAAN,CAAcT,KAAd,CAAJ,EAA0B,OAAO,OAAP;EAC1B,MAAI,QAAOA,KAAP,MAAiB,QAAjB,IAA6BA,iBAAiBU,MAAlD,EAA0D,OAAO,QAAP;EAC1D,SAAO,WAAP;EACD;;EAED,IAAMC,eAAe;EACnBH,SAAO,GADY;EAEnBE,UAAQ,GAFW;EAGnBE,kBAAgB,GAHG;EAInBC,kBAAgB;EAJG,CAArB;EAOA,IAAMC,gBAAgB;EACpBN,SAAO,GADa;EAEpBE,UAAQ,GAFY;EAGpBE,kBAAgB,GAHI;EAIpBC,kBAAgB;EAJI,CAAtB;;EAOA,SAASE,YAAT,CAAsBC,MAAtB,EAA8B;EAC5B;EACA;EAEA;EACA;EACA;EACA;EAEA,SAAOA,OAAOC,OAAP,CAAepB,WAAf,EAA4B,UAACqB,CAAD,EAAO;EACxC,QAAMC,IAAIrB,KAAKoB,CAAL,CAAV;EACA,WAAO,OAAOC,CAAP,KAAa,QAAb,GAAwBA,CAAxB,gBAAkCD,EAAEE,UAAF,CAAa,CAAb,EAAgBC,QAAhB,CAAyB,EAAzB,EAA6BC,QAA7B,CAAsC,CAAtC,EAAyC,GAAzC,CAAlC,CAAP;EACD,GAHM,CAAP;EAID;;EAED,SAASC,WAAT,CAAqBP,MAArB,EAA6B;EAC3B,qBAAWD,aAAaC,MAAb,CAAX;EACD;;EAED,SAASQ,cAAT,CAAwBC,SAAxB,EAAgCC,IAAhC,EAAsC;EACpC,MAAM1B,QAAQyB,UAAOxB,IAAP,CAAYyB,IAAZ,CAAd;;EACA,MAAI1B,UAAU,IAAd,EAAoB;EAClB,WAAO,aAAY,UAAC2B,OAAD,EAAUC,MAAV,EAAqB;EACtC,UAAMC,cAAc,SAAdA,WAAc;EAAA,eAAMF,QAAQ,IAAR,CAAN;EAAA,OAApB;;EACAF,gBAAOvB,IAAP,CAAY,KAAZ,EAAmB2B,WAAnB;EACAJ,gBAAOvB,IAAP,CAAY,OAAZ,EAAqB0B,MAArB;EACAH,gBAAOvB,IAAP,CAAY,UAAZ,EAAwB,YAAM;EAC5BuB,kBAAOtB,cAAP,CAAsB,KAAtB,EAA6B0B,WAA7B;EACAJ,kBAAOtB,cAAP,CAAsB,OAAtB,EAA+ByB,MAA/B;EACAD,gBAAQF,UAAOxB,IAAP,EAAR;EACD,OAJD;EAKD,KATM,CAAP;EAUD;;EACD,SAAO,SAAQ0B,OAAR,CAAgB3B,KAAhB,CAAP;EACD;;EAED,SAAS8B,gBAAT,CAA0BC,OAA1B,EAAmC;EACjC,SAAOA,QAAQzB,IAAR,CAAa,UAAC0B,GAAD,EAAS;EAC3B,QAAMC,UAAU5B,QAAQ2B,GAAR,CAAhB;EACA,WAAOC,YAAY,SAAZ,GAAwBH,iBAAiBE,GAAjB,CAAxB,GAAgDA,GAAvD;EACD,GAHM,CAAP;EAID;;MAEKE;;;;;EACJ,+BAAYlC,KAAZ,EAAmBmC,QAAnB,EAA6BC,MAA7B,EAAqCC,KAArC,EAA4C;EAAA;;EAAA;;EAC1C,6FAAM,EAAN;EACA,QAAIC,GAAJ;;EACA,QAAMC,oBAAmBH,MAAnB,CAAN;;EACA,QAAIG,cAAc,QAAd,IAA0BA,cAAc,QAA5C,EAAsD;EACpDD,YAAM,iBAAgBF,MAAhB,IAA0B,IAAII,MAAJ,CAAWJ,MAAX,CAA1B,GAA+CA,MAArD;EACD;;EACD,0EAAoB;EAClBK,eAASJ,QAAQ,cAAR,GAAwB,cADf;EAElBA,kBAFkB;EAGlBK,aAAO,EAHW;EAIlBC,wBAAkBR,oBAAoBS,QAApB,IAAgCT,QAJhC;EAKlBU,qBAAerC,MAAMC,OAAN,CAAc0B,QAAd,KAA2BA,QALxB;EAMlBG,cANkB;EAOlBQ,aAAO;EAPW,KAApB;;EASA,UAAKC,UAAL,CAAgB/C,KAAhB;;EAhB0C;EAiB3C;;;;6BAEMgD,KAAKhD,OAAO;EACjB,UAAMiD,eAAe,KAAKR,OAAL,CAAaS,GAAb,CAAiBlD,KAAjB,CAArB;;EACA,UAAIiD,YAAJ,EAAkB;EAChB,eAAO;EACLE,gBAAMF;EADD,SAAP;EAGD;;EACD,UAAIG,OAAO,KAAKA,IAAL,EAAX;EACA,UAAIJ,QAAQK,SAAZ,EAAuBD,KAAKE,IAAL,CAAUN,GAAV;EACvBI,aAAOA,KAAKG,GAAL,CAAS;EAAA,0BAAU,kBAAiBC,CAAjB,IAAsBA,CAAtB,GAA0BjC,YAAYiC,CAAZ,CAApC;EAAA,OAAT,CAAP;EACA,WAAKf,OAAL,CAAagB,GAAb,CAAiBzD,KAAjB,EAAwBoD,KAAKM,MAAL,cAAkBN,KAAKO,IAAL,CAAU,EAAV,CAAlB,IAAoC,GAA5D;EACA,aAAO3D,KAAP;EACD;;;iCAEUA,OAAOgD,KAAKY,OAAO;EAAA;;EAC5B,UAAIC,YAAY7D,KAAhB;;EACA,UAAI,KAAK2C,gBAAT,EAA2B;EACzBkB,oBAAY,KAAKlB,gBAAL,CAAsBK,OAAOY,KAA7B,EAAoCC,SAApC,EAA+C,IAA/C,CAAZ;EACD,OAJ2B;;;EAM5B,UAAIA,aAAaA,UAAUC,MAAV,YAA4BlB,QAA7C,EAAuD;EACrDiB,oBAAYA,UAAUC,MAAV,EAAZ;EACD;;EACD,UAAID,qBAAqBjB,QAArB,IAAiC,QAAO5C,KAAP,MAAiB,QAAtD,EAAgE;EAC9D6D,oBAAYR,SAAZ;EACD;;EACD,UAAIL,QAAQK,SAAR,IAAqB,KAAKR,aAA9B,EAA6C;EAC3C,YAAI,CAAC,KAAKA,aAAL,CAAmBkB,QAAnB,CAA4Bf,GAA5B,CAAL,EAAuC;EACrCa,sBAAYR,SAAZ;EACD;EACF;;EACD,UAAIW,OAAO3D,QAAQwD,SAAR,CAAX;;EACA,UAAIA,cAAcR,SAAd,IAA2BW,SAAS,SAApC,IAAiDhB,GAArD,EAA0D;EACxD,YAAI,KAAKV,GAAT,EAAc;EACZ,eAAK2B,KAAL,aAAgB,KAAK3B,GAAL,CAASE,MAAT,CAAgB,KAAKM,KAArB,CAAhB,eAA+C/B,aAAaiC,GAAb,CAA/C;EACD,SAFD,MAEO;EACL,eAAKiB,KAAL,aAAelD,aAAaiC,GAAb,CAAf;EACD;EACF;;EACD,UAAIgB,SAAS,WAAb,EAA0B;EACxB,YAAI,KAAK3B,KAAT,EAAgB;EACd;EACAwB,sBAAY,KAAKK,MAAL,CAAYlB,OAAOY,KAAnB,EAA0BC,SAA1B,CAAZ;EACAG,iBAAO3D,QAAQwD,SAAR,CAAP;EACD,SAJD,MAIO;EACL;EACA,cAAI,KAAKpB,OAAL,CAAa0B,GAAb,CAAiBN,SAAjB,CAAJ,EAAiC;EAC/B,kBAAM,eAAc,IAAIO,KAAJ,CAAU,uCAAV,CAAd,EAAkE;EACtEP,kCADsE;EAEtEb,mBAAKA,OAAOY;EAF0D,aAAlE,CAAN;EAID;;EACD,eAAKnB,OAAL,CAAa4B,GAAb,CAAiBR,SAAjB;EACD;EACF;;EAED,UAAI,CAACb,GAAD,IAAQY,QAAQ,CAAC,CAAjB,IAAsB,KAAKd,KAA3B,IAAoC,KAAKR,GAA7C,EAAkD,KAAK2B,KAAL,aAAgB,KAAK3B,GAAL,CAASE,MAAT,CAAgB,KAAKM,KAArB,CAAhB;EAElD,UAAMwB,OAAOxD,cAAckD,IAAd,CAAb;EACA,UAAIM,IAAJ,EAAU,KAAKL,KAAL,CAAWK,IAAX;EAEV,UAAMC,MAAM;EACVvB,gBADU;EAEVY,oBAFU;EAGVI,kBAHU;EAIVhE,eAAO6D;EAJG,OAAZ;;EAOA,UAAIG,SAAS,QAAb,EAAuB;EACrB,aAAKlB,KAAL,IAAc,CAAd;EACAyB,YAAIC,MAAJ,GAAa,aAAYX,SAAZ,CAAb;EACAU,YAAIE,OAAJ,GAAc,CAACF,IAAIC,MAAJ,CAAWd,MAA1B;EACD,OAJD,MAIO,IAAIM,SAAS,OAAb,EAAsB;EAC3B,aAAKlB,KAAL,IAAc,CAAd;EACAyB,YAAIC,MAAJ,GAAa,YAAWhE,MAAMqD,UAAUH,MAAhB,EAAwBgB,IAAxB,EAAX,CAAb;EACAH,YAAIE,OAAJ,GAAc,CAACF,IAAIC,MAAJ,CAAWd,MAA1B;EACD,OAJM,MAIA,IAAIM,KAAKW,UAAL,CAAgB,UAAhB,CAAJ,EAAiC;EACtC,aAAK7B,KAAL,IAAc,CAAd;;EACA,YAAIe,UAAUzD,cAAV,CAAyBwE,KAA7B,EAAoC;EAClC,eAAKC,IAAL,CAAU,OAAV,EAAmB,IAAIT,KAAJ,CAAU,oFAAV,CAAnB,EAAoHP,SAApH,EAA+Hb,OAAOY,KAAtI;EACD,SAFD,MAEO,IAAIC,UAAUzD,cAAV,CAAyB0E,OAA7B,EAAsC;EAC3CjB,oBAAUkB,KAAV;EACA,eAAKF,IAAL,CAAU,OAAV,EAAmB,IAAIT,KAAJ,CAAU,sFAAV,CAAnB,EAAsHP,SAAtH,EAAiIb,OAAOY,KAAxI;EACD;;EACDW,YAAIS,SAAJ,GAAgB,CAAhB;EACAnB,kBAAU3D,IAAV,CAAe,KAAf,EAAsB,YAAM;EAC1BqE,cAAIU,GAAJ,GAAU,IAAV;;EACA,iBAAKC,MAAL;EACD,SAHD;EAIArB,kBAAU3D,IAAV,CAAe,OAAf,EAAwB,UAACiF,GAAD,EAAS;EAC/B,iBAAKC,KAAL,GAAa,IAAb;;EACA,iBAAKP,IAAL,CAAU,OAAV,EAAmBM,GAAnB;EACD,SAHD;EAIAZ,YAAIc,KAAJ,GAAY,IAAZ;EACD;;EACD,WAAK3C,KAAL,CAAW4C,OAAX,CAAmBf,GAAnB;EACA,aAAOA,GAAP;EACD;;;sCAEegB,MAAM;EAAA,UAElBvB,IAFkB,GAGhBuB,IAHgB,CAElBvB,IAFkB;EAIpB,UAAMwB,WAAWxB,SAAS,QAAT,IAAqBA,SAAS,OAA9B,IAAyCA,KAAKW,UAAL,CAAgB,UAAhB,CAA1D;;EACA,UAAIX,SAAS,WAAb,EAA0B;EACxB,YAAI,CAAC,KAAK3B,KAAV,EAAiB;EACf,eAAKI,OAAL,CAAagD,MAAb,CAAoBF,KAAKvF,KAAzB;EACD;;EACD,YAAIwF,QAAJ,EAAc;EACZ,eAAK1C,KAAL,IAAc,CAAd;EACD;EACF;;EAED,UAAMmC,MAAMtE,aAAaqD,IAAb,CAAZ;EACA,UAAIwB,YAAY,CAACD,KAAKd,OAAlB,IAA6B,KAAKnC,GAAtC,EAA2C,KAAK2B,KAAL,aAAgB,KAAK3B,GAAL,CAASE,MAAT,CAAgB,KAAKM,KAArB,CAAhB;EAC3C,UAAImC,GAAJ,EAAS,KAAKhB,KAAL,CAAWgB,GAAX;;EACT,UAAIM,KAAKG,oBAAT,EAA+B;EAC7B,aAAKzB,KAAL,CAAW,GAAX;EACD;;EACD,WAAKvB,KAAL,CAAWiD,MAAX,CAAkB,KAAKjD,KAAL,CAAWkD,OAAX,CAAmBL,IAAnB,CAAlB,EAA4C,CAA5C;EACD;;;4BAEKM,MAAM;EACV,WAAKC,UAAL,GAAkB,IAAlB;EACA,WAAKxC,IAAL,CAAUuC,IAAV;EACD;;;4CAEqBE,SAASrE,MAAM;EAAA;;EACnC,UAAIqE,QAAQd,GAAZ,EAAiB;EACf,aAAKe,eAAL,CAAqBD,OAArB;EACA,eAAO1C,SAAP;EACD;;EACD,aAAO7B,eAAeuE,QAAQ/F,KAAvB,EAA8B0B,IAA9B,EACJpB,IADI,CACC,UAACN,KAAD,EAAW;EACf,YAAIA,UAAU,IAAd,EAAoB;EAClB,cAAI,CAAC+F,QAAQV,KAAb,EAAoB;EAClB,mBAAKpB,KAAL,CAAW,GAAX;EACD;EACD;;;EACA8B,kBAAQV,KAAR,GAAgB,KAAhB;;EACA,iBAAKtC,UAAL,CAAgB/C,KAAhB,EAAuBqD,SAAvB,EAAkC0C,QAAQf,SAA1C;;EACAe,kBAAQf,SAAR,IAAqB,CAArB;EACA;EACD;EACF,OAZI,CAAP;EAaD;;;oCAEae,SAAS;EACrB,UAAI,CAACA,QAAQvB,MAAR,CAAed,MAApB,EAA4B;EAC1B,aAAKsC,eAAL,CAAqBD,OAArB;EACA;EACD;;EACD,UAAM/C,MAAM+C,QAAQvB,MAAR,CAAeyB,KAAf,EAAZ;EACA,UAAMjG,QAAQ+F,QAAQ/F,KAAR,CAAcgD,GAAd,CAAd;EAEA,WAAKD,UAAL,CAAgB/C,KAAhB,EAAuB+F,QAAQ/B,IAAR,KAAiB,QAAjB,IAA6BhB,GAApD,EAAyD+C,QAAQ/B,IAAR,KAAiB,OAAjB,IAA4BhB,GAArF,EAA0F0C,oBAA1F,GAAiH,CAAC,CAACK,QAAQvB,MAAR,CAAed,MAAlI;EACD;;;mCAEYqC,SAAS;EACpB,aAAO,KAAKG,aAAL,CAAmBH,OAAnB,CAAP;EACD;;;uCAEgBA,SAAS;EACxB,UAAIA,QAAQ/F,KAAR,KAAkBqD,SAAtB,EAAiC;EAC/B,YAAMW,eAAc+B,QAAQ/F,KAAtB,CAAN;;EACA,YAAIA,KAAJ;;EACA,gBAAQgE,IAAR;EACA,eAAK,QAAL;EACEhE,oBAAQuB,YAAYwE,QAAQ/F,KAApB,CAAR;EACA;;EACF,eAAK,QAAL;EACEA,oBAAQ,iBAAgB+F,QAAQ/F,KAAxB,IAAiCmG,OAAOJ,QAAQ/F,KAAf,CAAjC,GAAyD,MAAjE;EACA;;EACF,eAAK,SAAL;EACA,eAAK,MAAL;EACEA,oBAAQmG,OAAOJ,QAAQ/F,KAAf,CAAR;EACA;;EACF,eAAK,QAAL;EACE,gBAAI,CAAC+F,QAAQ/F,KAAb,EAAoB;EAClBA,sBAAQ,MAAR;EACA;EACD;;EACD;;EACF;EACE;EACA;EACA,kBAAM,eAAc,IAAIoE,KAAJ,0BAA2BJ,IAA3B,+BAAd,EAA0E;EAC9EhE,qBAAO+F,QAAQ/F;EAD+D,aAA1E,CAAN;EApBF;;EAwBA,aAAKiE,KAAL,CAAWjE,KAAX;EACD,OA5BD,MA4BO,IAAI,KAAK0C,KAAL,CAAW,CAAX,MAAkB,KAAKA,KAAL,CAAW,CAAX,EAAcsB,IAAd,KAAuB,OAAvB,IAAkC,KAAKtB,KAAL,CAAW,CAAX,EAAcsB,IAAd,KAAuB,gBAA3E,CAAJ,EAAkG;EACvG,aAAKC,KAAL,CAAW,MAAX;EACD,OAFM,MAEA;EACL;EACA8B,gBAAQL,oBAAR,GAA+B,KAA/B;EACD;;EACD,WAAKM,eAAL,CAAqBD,OAArB;EACD;;;4CAEqBA,SAASrE,MAAM;EAAA;;EACnC,UAAIqE,QAAQd,GAAZ,EAAiB;EACf,aAAKe,eAAL,CAAqBD,OAArB;EACA,eAAO1C,SAAP;EACD;;EACD,aAAO7B,eAAeuE,QAAQ/F,KAAvB,EAA8B0B,IAA9B,EACJpB,IADI,CACC,UAACN,KAAD,EAAW;EACf,YAAIA,KAAJ,EAAW,OAAKiE,KAAL,CAAWlD,aAAaf,MAAMqB,QAAN,EAAb,CAAX;EACZ,OAHI,CAAP;EAID;;;qCAEc0E,SAAS;EAAA;;EACtB,aAAOjE,iBAAiBiE,QAAQ/F,KAAzB,EAAgCM,IAAhC,CAAqC,UAACN,KAAD,EAAW;EAAA,YAEnD0F,oBAFmD,GAGjDK,OAHiD,CAEnDL,oBAFmD;EAIrD;;EACAK,gBAAQL,oBAAR,GAA+B,KAA/B;;EACA,eAAKM,eAAL,CAAqBD,OAArB;;EACA,eAAKhD,UAAL,CAAgB/C,KAAhB,EAAuB+F,QAAQ/C,GAA/B,EAAoC+C,QAAQnC,KAA5C,EACG8B,oBADH,GAC0BA,oBAD1B;EAED,OATM,CAAP;EAUD;;;0CAEmBhE,MAAM;EAAA;;EACxB,UAAMqE,UAAU,KAAKrD,KAAL,CAAW,CAAX,CAAhB;EACA,UAAI,CAACqD,OAAD,IAAY,KAAKX,KAArB,EAA4B,OAAO,SAAQzD,OAAR,EAAP;EAC5B,UAAIyE,GAAJ;;EACA,UAAI;EACFA,cAAM,sBAAeL,QAAQ/B,IAAvB,GAA+B+B,OAA/B,EAAwCrE,IAAxC,CAAN;EACD,OAFD,CAEE,OAAOyD,GAAP,EAAY;EACZ,eAAO,SAAQvD,MAAR,CAAeuD,GAAf,CAAP;EACD;;EACD,aAAO,SAAQxD,OAAR,CAAgByE,GAAhB,EACJ9F,IADI,CACC,YAAM;EACV,YAAI,OAAKoC,KAAL,CAAWgB,MAAX,KAAsB,CAA1B,EAA6B;EAC3B,iBAAKuB,GAAL,GAAW,IAAX;;EACA,iBAAKhB,KAAL,CAAW,IAAX;EACD;EACF,OANI,CAAP;EAOD;;;6BAEMvC,MAAM;EAAA;;EACX,UAAI,KAAK2E,SAAL,IAAkB,KAAKjB,KAA3B,EAAkC;EAChC,aAAKkB,QAAL,GAAgB,IAAhB;EACA,eAAOjD,SAAP;EACD;;EACD,WAAKgD,SAAL,GAAiB,IAAjB,CALW;;EAQX,WAAKC,QAAL,GAAgB,KAAhB;EACA,aAAO,KAAKC,mBAAL,CAAyB7E,IAAzB,EACJpB,IADI,CACC,YAAM;EACV,YAAMkG,YAAY,CAAC,OAAKvB,GAAN,IAAa,CAAC,OAAKG,KAAnB,KAA6B,OAAKkB,QAAL,IAAiB,CAAC,OAAKR,UAApD,CAAlB;;EACA,YAAIU,SAAJ,EAAe;EACb,wBAAa,YAAM;EACjB,mBAAKH,SAAL,GAAiB,KAAjB;;EACA,mBAAKnB,MAAL;EACD,WAHD;EAID,SALD,MAKO;EACL,iBAAKmB,SAAL,GAAiB,KAAjB;EACD;EACF,OAXI,EAYJI,KAZI,CAYE,UAACtB,GAAD,EAAS;EACd,eAAKC,KAAL,GAAa,IAAb;;EACA,eAAKP,IAAL,CAAU,OAAV,EAAmBM,GAAnB;EACD,OAfI,CAAP;EAgBD;;;4BAEKzD,MAAM;EACV,WAAKoE,UAAL,GAAkB,KAAlB;;EACA,WAAKZ,MAAL,CAAYxD,IAAZ;EACD;;;6BAEM;EACL,aAAO,KAAKgB,KAAL,CAAWa,GAAX,CAAe;EAAA,YACpBP,GADoB,QACpBA,GADoB;EAAA,YAEpBY,KAFoB,QAEpBA,KAFoB;EAAA,eAGhBZ,OAAOY,KAHS;EAAA,OAAf,EAGa8C,MAHb,CAGoB;EAAA,eAAKlD,KAAKA,IAAI,CAAC,CAAf;EAAA,OAHpB,EAGsCmD,OAHtC,EAAP;EAID;;;;IA3S+BC;;;;;;;;"} |
+36
-26
| { | ||
| "name": "json-stream-stringify", | ||
| "version": "1.6.1", | ||
| "description": "JSON.Stringify as a readable stream", | ||
| "version": "2.0.0", | ||
| "license": "MIT", | ||
| "author": "Faleij <faleij@gmail.com> (https://github.com/faleij)", | ||
| "repository": { | ||
@@ -9,31 +11,39 @@ "type": "git", | ||
| }, | ||
| "main": "jsonStreamify.js", | ||
| "dependencies": {}, | ||
| "devDependencies": { | ||
| "coveralls": "2.11.9", | ||
| "istanbul": "0.4.3", | ||
| "expect.js": "0.3.1", | ||
| "mocha": "2.4.5" | ||
| "bugs": { | ||
| "url": "https://github.com/faleij/json-stream-stringify/issues" | ||
| }, | ||
| "main": "./umd.js", | ||
| "module": "./module.js", | ||
| "browser": "./umd.js", | ||
| "scripts": { | ||
| "test": "mocha", | ||
| "coverage": "istanbul cover node_modules/mocha/bin/_mocha -- test.js -R spec" | ||
| "lint": "eslint . && echo \"eslint: no lint errors\"", | ||
| "build": "rollup -c rollup.config.js && babel test-src --out-dir test", | ||
| "build:watch": "rollup -c rollup.config.js --watch", | ||
| "test": "mocha -R spec -b", | ||
| "coverage": "nyc npm test", | ||
| "coveralls": "nyc report --reporter=text-lcov | coveralls" | ||
| }, | ||
| "keywords": [ | ||
| "JSON", | ||
| "stringify", | ||
| "stream", | ||
| "string", | ||
| "streamify", | ||
| "read", | ||
| "readable", | ||
| "co", | ||
| "generator", | ||
| "iterable" | ||
| ], | ||
| "author": "Faleij", | ||
| "license": "MIT", | ||
| "engines": { | ||
| "node": ">=4.2.2" | ||
| "devDependencies": { | ||
| "@babel/cli": "^7.0.0-beta.51", | ||
| "@babel/core": "^7.0.0-beta.51", | ||
| "@babel/plugin-transform-runtime": "^7.0.0-beta.51", | ||
| "@babel/polyfill": "^7.0.0-beta.51", | ||
| "@babel/preset-env": "^7.0.0-beta.51", | ||
| "@babel/runtime": "^7.0.0-beta.51", | ||
| "babel-plugin-external-helpers": "^6.22.0", | ||
| "babel-register": "^6.26.0", | ||
| "coveralls": "3.0.1", | ||
| "eslint": "^4.19.1", | ||
| "eslint-config-airbnb": "^17.0.0", | ||
| "eslint-plugin-import": "^2.12.0", | ||
| "eslint-plugin-jsx-a11y": "^6.0.3", | ||
| "eslint-plugin-mocha": "^5.0.0", | ||
| "eslint-plugin-react": "^7.9.1", | ||
| "expect.js": "0.3.1", | ||
| "istanbul": "0.4.5", | ||
| "mocha": "3.5.3", | ||
| "nyc": "12.0.2", | ||
| "rollup": "0.60.4", | ||
| "rollup-plugin-babel": "^4.0.0-beta.5" | ||
| } | ||
| } |
+92
-41
| # JSON Stream Stringify | ||
| [![NPM version][npm-image]][npm-url] | ||
| [![NPM Downloads][downloads-image]][downloads-url] | ||
| [![Dependency Status][dependency-image]][dependency-url] | ||
| [![Build Status][travis-image]][travis-url] | ||
| [![Coverage Status][coveralls-image]][coveralls-url] | ||
| [![License][license-image]](LICENSE) | ||
| [![Gratipay][gratipay-image]][gratipay-url] | ||
| [![Donate][donate-image]][donate-url] | ||
| JSON Stringify as a Readable Stream with rescursive resolving of any readable streams and Promises. | ||
| ## Important and Breaking Changes in v2 | ||
| - Completely rewritten from scratch | ||
| - 100% Code Coverage! 🎉 | ||
| - Space argument finally implemented! 🎉 | ||
| - ⚠️ Cycling is off by default | ||
| - ⚠️ JsonStreamStringify is now a constructor; use ``new`` operator | ||
| - Removed dependency on global JSON.stringify, Async/Await and Generators | ||
| - JsonStreamStringify is now compiled with babel to target ES5 (polyfills needed) | ||
| - Rejected promises and input stream errors are now handled and emitted as errors | ||
| - Added cyclic structure detection to prevent infinite recursion | ||
| ## Main Features | ||
| - Promises are rescursively resolved and the result is piped through JSONStreamStreamify | ||
| - Streams (ObjectMode) are piped through a transform which pipes the data through JSONStreamStreamify (enabling recursive resolving) | ||
| - Streams (Non-ObjectMode) is stringified and piped | ||
| - Promises are rescursively resolved and the result is piped through JsonStreamStringify | ||
| - Streams (Object mode) are recursively read and output as arrays | ||
| - Streams (Non-Object mode) are output as a single string | ||
| - Output is streamed optimally with as small chunks as possible | ||
| - Decycling using Douglas Crockfords Cycle algorithm | ||
| - Great memory management with reference release post process (When a key and value has been processed the value is dereferenced) | ||
| - Stream pressure handling | ||
| - Cycling of cyclical structures and dags using [Douglas Crockfords cycle algorithm](https://github.com/douglascrockford/JSON-js)* | ||
| - Great memory management with reference release after processing and WeakMap/Set reference handling | ||
| - Optimal stream pressure handling | ||
| - Tested and runs on ES5** and ES2015 | ||
| - Bundled as UMD and Module | ||
| \* Off by default since v2 | ||
| \** With polyfills | ||
| ## Install | ||
@@ -25,28 +40,80 @@ | ||
| npm install --save json-stream-stringify | ||
| # Optional if you need polyfills | ||
| # Make sure to include these if you target NodeJS <=v6 or browsers | ||
| npm install --save @babel/polyfill @babel/runtime | ||
| ``` | ||
| ## Usage | ||
| Using Node v8 or later with ESM / Webpack / Browserify / Rollup | ||
| ```javascript | ||
| // No Polyfills | ||
| import JsonStreamStringify from 'JsonStreamStringify'; | ||
| ``` | ||
| ```javascript | ||
| // Polyfilled; loads only needed polyfills from @babel/polyfill @babel/runtime | ||
| import JsonStreamStringify from 'JsonStreamStringify/module.polyfill'; | ||
| ``` | ||
| Using Node >=8 / Other ES2015 environments | ||
| ```javascript | ||
| const JsonStreamStringify = require('JsonStreamStringify'); | ||
| ``` | ||
| Using Node <=6 / Other ES5 environments | ||
| ```javascript | ||
| var JsonStreamStringify = require('JsonStreamStringify/umd.polyfill'); | ||
| ``` | ||
| **Note:** This library is primarily written for LTS versions of NodeJS. Other environments are not tested. | ||
| **Note on non-NodeJS usage:** This module depends on node streams library. Any Streams3 compatible implementation should work - as long as it exports a Readable class, with instances that looks like readable streams. | ||
| **Note on Polyfills:** I have taken measures to minify global pollution of polyfills but this library **does not load polyfills by default** because the polyfills modify native object prototypes and it goes against the [W3C recommendations](https://www.w3.org/2001/tag/doc/polyfills/#advice-for-library-and-framework-authors). | ||
| ## API | ||
| ### JSONStreamStringify(value[, replacer[, spaces[, noDecycle]]]) | ||
| Convert value to JSON string. Returns a readable stream. | ||
| - ``value`` Any data to convert to JSON. | ||
| - ``replacer`` Optional ``Function(key, value)`` or ``Array``. | ||
| As a function the returned value replaces the value associated with the key. [Details](https://developer.mozilla.org/en/docs/Web/JavaScript/Reference/Global_Objects/JSON/stringify#The_replacer_parameter) | ||
| ### `new JsonStreamStringify(value[, replacer[, spaces[, cycle]]])` | ||
| Streaming conversion of ``value`` to JSON string. | ||
| **Parameters** | ||
| - ``value`` ``Any`` | ||
| Data to convert to JSON. | ||
| - ``replacer`` Optional ``Function(key, value)`` or ``Array`` | ||
| As a function the returned value replaces the value associated with the key. [Details](https://developer.mozilla.org/en/docs/Web/JavaScript/Reference/Global_Objects/JSON/stringify#The_replacer_parameter) | ||
| As an array all other keys are filtered. [Details](https://developer.mozilla.org/en/docs/Web/JavaScript/Reference/Global_Objects/JSON/stringify#Example_with_an_array) | ||
| - ``spaces`` Optional ``String`` or ``Number`` **Not yet implemented** | ||
| - ``noDecycle`` Optional ``Boolean`` Set to ``true`` to disable decycling. | ||
| - ``spaces`` Optional ``String`` or ``Number`` | ||
| A String or Number object that's used to insert white space into the output JSON string for readability purposes. If this is a Number, it indicates the number of space characters to use as white space. If this is a String, the string is used as white space. If this parameter is not recognized as a finite number or valid string, no white space is used. | ||
| - ``cycle`` Optional ``Boolean`` | ||
| ``true`` enables cycling of cyclical structures and dags. | ||
| To restore cyclical structures; use [Crockfords Retrocycle method](https://github.com/douglascrockford/JSON-js) on the parsed object (not included in this module). | ||
| **Returns** | ||
| - ``JsonStreamStringify`` object that exposes a [Streams3 interface](https://nodejs.org/api/stream.html#stream_class_stream_readable). | ||
| ### jsonStreamStringify#path | ||
| **Returns** | ||
| - ``Array[String, Number]`` | ||
| Current path being serialized as an array of Strings (keys of objects) and Numbers (index into arrays). | ||
| Can be transformed into an mpath with ``.join('.')``. | ||
| Useful in conjunction with ``.on('error', ...)``, for figuring out what path may have caused the error. | ||
| ## Example Usage | ||
| ```javascript | ||
| const JSONStreamStringify = require('json-stream-stringify'); | ||
| const JsonStreamStringify = require('json-stream-stringify'); | ||
| JSONStreamStringify({ | ||
| aPromise: Promise.resolve(Promise.resolve("text")), // Promise may resolve more promises and streams which will be consumed and resolved | ||
| aStream: ReadableObjectStream({a:1}, 'str'), // Stream may write more streams and promises which will be consumed and resolved | ||
| const jsonStream = new JsonStreamStringify({ | ||
| // Promises and Streams may resolve more promises and/or streams which will be consumed and processed into json output | ||
| aPromise: Promise.resolve(Promise.resolve("text")), | ||
| aStream: ReadableObjectStream({a:1}, 'str'), | ||
| arr: [1, 2, Promise.resolve(3), Promise.resolve([4, 5]), ReadableStream('a', 'b', 'c')], | ||
| date: new Date(2016, 0, 2) | ||
| }).pipe(process.stdout); | ||
| }); | ||
| jsonStream.once('error', () => console.log('Error at path', jsonStream.stack.join('.'))); | ||
| jsonStream.pipe(process.stdout); | ||
| ``` | ||
| Output (each line represents a write from JSONStreamStringify) | ||
| Output (each line represents a write from jsonStreamStringify) | ||
| ``` | ||
@@ -92,19 +159,5 @@ { | ||
| ```javascript | ||
| app.get('/api/users', (req, res, next) => JSONStreamStringify(Users.find().stream()).pipe(res)); | ||
| app.get('/api/users', (req, res, next) => new JsonStreamStringify(Users.find().stream()).pipe(res)); | ||
| ``` | ||
| ## TODO | ||
| - Space option | ||
| Feel free to contribute. | ||
| ## Technical Notes | ||
| Uses toJSON when available, and JSON.stringify to stringify everything but objects and arrays. | ||
| Streams with ObjectMode=true are output as arrays while ObjectMode=false output as a concatinated string (each chunk is piped with transforms). | ||
| Circular structures are handled using a WeakMap based implementation of [Douglas Crockfords Decycle method](https://github.com/douglascrockford/JSON-js/blob/master/cycle.js). To restore circular structures; use Crockfords Retrocycle method on the parsed object. | ||
| ## Requirements | ||
| NodeJS >4.2.2 | ||
| # License | ||
@@ -119,4 +172,2 @@ [MIT](LICENSE) | ||
| [downloads-url]: https://npmjs.org/package/json-stream-stringify | ||
| [dependency-image]: https://gemnasium.com/Faleij/json-stream-stringify.svg | ||
| [dependency-url]: https://gemnasium.com/Faleij/json-stream-stringify | ||
| [travis-image]: https://travis-ci.org/Faleij/json-stream-stringify.svg?branch=master | ||
@@ -127,3 +178,3 @@ [travis-url]: https://travis-ci.org/Faleij/json-stream-stringify | ||
| [license-image]: https://img.shields.io/badge/license-MIT-blue.svg | ||
| [gratipay-image]: https://img.shields.io/gratipay/faleij.svg | ||
| [gratipay-url]: https://gratipay.com/faleij/ | ||
| [donate-image]: https://img.shields.io/badge/Donate-PayPal-green.svg | ||
| [donate-url]: https://www.paypal.com/cgi-bin/webscr?cmd=_donations&business=faleij%40gmail%2ecom&lc=GB&item_name=faleij&item_number=jsonStreamStringify¤cy_code=SEK&bn=PP%2dDonationsBF%3abtn_donate_SM%2egif%3aNonHosted |
-10
| language: node_js | ||
| node_js: | ||
| - '6' | ||
| - '8' | ||
| - '10' | ||
| sudo: false | ||
| script: | ||
| - "npm run coverage" | ||
| after_script: | ||
| - "test -e ./coverage/lcov.info && cat ./coverage/lcov.info | coveralls" |
-69
| 'use strict'; | ||
| const PassThrough = require('stream').PassThrough; | ||
| const isReadableStream = require('./utils').isReadableStream; | ||
| class CoStream extends PassThrough { | ||
| constructor(args) { | ||
| super(); | ||
| this._generator = this._makeGenerator.apply(this, args); | ||
| } | ||
| // You need to implement your logic in this generator | ||
| * _makeGenerator() { | ||
| yield new Error('You need to implement _makeGenerator'); | ||
| } | ||
| // Handle results from generator | ||
| _handle(result) { | ||
| if (result.value === false) { | ||
| // Abort feed | ||
| this._running = false; | ||
| return; | ||
| } | ||
| if (result.value === true) { | ||
| // Continue to feed | ||
| this._handle(this._generator.next()); | ||
| return; | ||
| } | ||
| if (result.done) { | ||
| // Feeding done | ||
| this._done = result.done; | ||
| return this.push(null); | ||
| } | ||
| if (isReadableStream(result.value)) { | ||
| // Pipe streams and continue feeding afterwards | ||
| return result.value.once('end', () => this._handle(this._generator.next())).pipe(this, { | ||
| end: false | ||
| }); | ||
| } | ||
| if (result.value instanceof Promise) { | ||
| // Resolve promises | ||
| return Promise.resolve(result.value).then((res) => { | ||
| this._handle(this._generator.next(res)); | ||
| }); | ||
| } | ||
| } | ||
| // Read from stream | ||
| _read(n) { | ||
| super._read(n); | ||
| if (this._done) { | ||
| return false; | ||
| } | ||
| if (!this._running) { | ||
| this._running = true; | ||
| this._handle(this._generator.next()); | ||
| } | ||
| return !this._done; | ||
| } | ||
| } | ||
| module.exports = CoStream; |
-100
| 'use strict'; | ||
| const Transform = require('stream').Transform; | ||
| const PassThrough = require('stream').PassThrough; | ||
| const CoStream = require('./coStream'); | ||
| const RecursiveIterable = require('./recursiveIterable'); | ||
| const isReadableStream = require('./utils').isReadableStream; | ||
| class JSONStreamify extends CoStream { | ||
| constructor(value, replacer, space, _visited, _stack) { | ||
| super(arguments); | ||
| this._iter = new RecursiveIterable(replacer instanceof Function ? replacer(undefined, value) : value, replacer, space, _visited, _stack); | ||
| } | ||
| * _makeGenerator(value, replacer) { | ||
| let insertSeparator = false; | ||
| for (let obj of this._iter) { | ||
| if (obj.state === 'close') { | ||
| insertSeparator = true; | ||
| yield this.push(obj.type === Object ? '}' : ']'); | ||
| continue; | ||
| } | ||
| if (obj.state === 'open') { | ||
| insertSeparator = false; | ||
| yield this.push(obj.type === Object ? '{' : '['); | ||
| continue; | ||
| } | ||
| if (insertSeparator) { | ||
| yield this.push(','); | ||
| } | ||
| if (obj.key && obj.ctxType !== Array) { | ||
| yield this.push(JSON.stringify(obj.key) + ':'); | ||
| } | ||
| if (isReadableStream(obj.value)) { | ||
| if (!obj.value._readableState.objectMode) { | ||
| // Non Object Mode are emitted as a concatinated string | ||
| yield this.push('"'); | ||
| yield obj.value.pipe(new Transform({ | ||
| transform: (data, enc, next) => { | ||
| this.push(JSON.stringify(data.toString()).slice(1, -1)); | ||
| next(null); | ||
| } | ||
| })); | ||
| yield this.push('"'); | ||
| continue; | ||
| } | ||
| // Object Mode Streams are emitted as arrays | ||
| yield this.push('['); | ||
| let first = true; | ||
| const pass = new PassThrough(); | ||
| let i = 0; | ||
| obj.value.pipe(new Transform({ | ||
| objectMode: true, | ||
| transform: (data, enc, next) => { | ||
| if (!first) { | ||
| pass.push(','); | ||
| } | ||
| first = false; | ||
| let stream = new JSONStreamify(data, this._iter.replacer, this._iter.space, this._iter.visited); | ||
| stream._iter._stack = obj.stack.concat(i++); | ||
| stream._iter._parentCtxType = Array; | ||
| stream.once('end', () => next(null, undefined)).pipe(pass, { | ||
| end: false | ||
| }); | ||
| } | ||
| })).once('end', () => pass.end()).resume(); | ||
| yield pass; | ||
| yield this.push(']'); | ||
| continue; | ||
| } | ||
| if (obj.state === 'circular') { | ||
| yield this.push(JSON.stringify({ $ref: `$${obj.value.map(v => `[${JSON.stringify(v)}]`).join('')}` })); | ||
| } | ||
| if (obj.value instanceof Promise) { | ||
| let childIterator = new RecursiveIterable(yield obj.value, this._iter.replacer, this._iter.space, this._iter.visited, obj.stack.concat(obj.key || []))[Symbol.iterator](); | ||
| obj.value = obj.attachChild(childIterator, obj.key); | ||
| insertSeparator = false; | ||
| continue; | ||
| } | ||
| if (obj.state === 'value') { | ||
| yield this.push(JSON.stringify(obj.value)); | ||
| } | ||
| insertSeparator = true; | ||
| } | ||
| this._iter = undefined; | ||
| } | ||
| } | ||
| module.exports = function (value, replacer, space, noDecycle) { | ||
| return new JSONStreamify(value, replacer, space, noDecycle ? { has: () => false, set: () => undefined } : undefined); | ||
| }; |
| 'use strict'; | ||
| const Readable = require('stream').Readable; | ||
| const isReadableStream = require('./utils').isReadableStream; | ||
| class RecursiveIterable { | ||
| constructor(obj, replacer, space, visited, stack) { | ||
| // Save a copy of the root object so we can be memory effective | ||
| if (obj && typeof obj.toJSON === 'function') { | ||
| obj = obj.toJSON(); | ||
| } | ||
| this.exclude = [Promise, { | ||
| __shouldExclude: isReadableStream | ||
| }]; | ||
| this._stack = stack || []; | ||
| this.visited = visited || new WeakMap(); | ||
| if (this._shouldIterate(obj)) { | ||
| this.isVisited = this.visited.has(obj); | ||
| if (!this.isVisited) { | ||
| // Save only unvisited stack to weakmap | ||
| this.visited.set(obj, this._stack.slice(0)); | ||
| } | ||
| } | ||
| this.obj = this._shouldIterate(obj) && !this.isVisited ? (Array.isArray(obj) ? obj.slice(0) : Object.assign({}, obj)) : obj; | ||
| this.replacerIsArray = Array.isArray(replacer); | ||
| this.replacer = replacer instanceof Function || this.replacerIsArray ? replacer : undefined; | ||
| this.space = space; | ||
| } | ||
| _shouldIterate(val) { | ||
| return val && typeof val === 'object' && !(this.exclude.some(v => v.__shouldExclude instanceof Function ? v.__shouldExclude(val) : val instanceof v)); | ||
| } | ||
| static _getType(obj) { | ||
| return Array.isArray(obj) ? Array : obj instanceof Object ? Object : undefined | ||
| } | ||
| [Symbol.iterator]() { | ||
| let isObject = this._shouldIterate(this.obj); | ||
| let ctxType = RecursiveIterable._getType(this.obj); | ||
| let nextIndex = 0; | ||
| let keys = isObject && (Array.isArray(this.obj) ? Array.from(Array(this.obj.length).keys()) : Object.keys(this.obj)); | ||
| let childIterator; | ||
| let closed = !isObject; | ||
| let opened = closed; | ||
| const attachIterator = (iterator, addToStack) => { | ||
| childIterator = iterator; | ||
| childIterator._stack = this._stack.concat(addToStack || []); | ||
| }; | ||
| const ctx = { | ||
| depth: 0, | ||
| type: ctxType, | ||
| next: () => { | ||
| let child = childIterator && childIterator.next(); | ||
| if (child) { | ||
| if (!child.done) { | ||
| return child; | ||
| } | ||
| childIterator = undefined; | ||
| } | ||
| let state; | ||
| let key; | ||
| let val; | ||
| let type; | ||
| if (!opened) { | ||
| if (this.isVisited) { | ||
| state = 'circular'; | ||
| val = this.visited.get(this.obj); | ||
| opened = closed = true; | ||
| keys.length = 0; | ||
| } else { | ||
| state = 'open'; | ||
| type = ctxType; | ||
| opened = true; | ||
| } | ||
| } else if (!closed && !keys.length) { | ||
| state = 'close'; | ||
| type = ctxType; | ||
| closed = true; | ||
| } else if (keys && keys.length) { | ||
| state = 'value'; | ||
| key = keys.shift(); | ||
| val = this.obj[key]; | ||
| if (this.replacerIsArray && this.replacer.indexOf(key) === -1) { | ||
| return ctx.next(); | ||
| } | ||
| } else if (!isObject && !ctx.done) { | ||
| state = 'value'; | ||
| val = this.obj; | ||
| ctx.done = true; | ||
| } | ||
| if (state === 'value') { | ||
| if (this.replacer && !this.replacerIsArray) { | ||
| val = this.replacer(key, val); | ||
| } | ||
| if (val && typeof val.toJSON === 'function') { | ||
| val = val.toJSON(); | ||
| } | ||
| if (typeof val === 'function') { | ||
| val = undefined; | ||
| } | ||
| if (val === undefined) { | ||
| if (key) { | ||
| // Dereference iterated object | ||
| this.obj[key] = undefined; | ||
| } | ||
| if ((this._parentCtxType ? this._parentCtxType !== Array : true) && ctx.type !== Array) { | ||
| return ctx.next(); | ||
| } | ||
| val = null; | ||
| } | ||
| if (this._shouldIterate(val)) { | ||
| if (this.visited.has(val)) { | ||
| state = 'circular'; | ||
| val = this.visited.get(val); | ||
| } else { | ||
| state = 'child'; | ||
| childIterator = new RecursiveIterable(val, this.replacer, this.space, this.visited, this._stack.concat(key))[Symbol.iterator](); | ||
| childIterator.ctxType = ctx.type; | ||
| childIterator.depth = ctx.depth + 1; | ||
| childIterator.type = RecursiveIterable._getType(val); | ||
| } | ||
| } | ||
| if (key) { | ||
| // Dereference iterated object | ||
| this.obj[key] = undefined; | ||
| } | ||
| } | ||
| return { | ||
| value: { | ||
| depth: ctx.depth, | ||
| key: key, | ||
| value: val, | ||
| state: state, | ||
| stack: this._stack.slice(0), | ||
| type: type, | ||
| ctxType: ctx.type, | ||
| attachChild: attachIterator | ||
| }, | ||
| done: !state | ||
| }; | ||
| } | ||
| }; | ||
| return ctx; | ||
| } | ||
| } | ||
| module.exports = RecursiveIterable; |
-173
| 'use strict'; | ||
| const mocha = require('mocha'); | ||
| const JSONStreamify = require('./jsonStreamify'); | ||
| const Readable = require('stream').Readable; | ||
| const expect = require('expect.js'); | ||
| function createTest(input, expected, ...args) { | ||
| return () => new Promise((resolve, reject) => { | ||
| let str = ''; | ||
| new JSONStreamify(input, ...args).on('data', data => str += data.toString()).once('end', () => { | ||
| try { | ||
| expect(str).to.equal(expected); | ||
| } catch (err) { | ||
| return reject(err); | ||
| } | ||
| resolve(); | ||
| }).once('error', reject); | ||
| }); | ||
| } | ||
| function ReadableStream() { | ||
| const stream = new Readable({ | ||
| objectMode: Array.from(arguments).some(v => typeof v !== 'string') | ||
| }); | ||
| Array.from(arguments).forEach(v => stream.push(v)); | ||
| stream.push(null); | ||
| return stream; | ||
| } | ||
| describe('Streamify', () => { | ||
| const date = new Date(); | ||
| it('null should be null', createTest(null, 'null')); | ||
| it('date should be date.toJSON()', createTest(date, `"${date.toJSON()}"`)); | ||
| it('true should be true', createTest(true, `true`)); | ||
| it('1 should be 1', createTest(1, `1`)); | ||
| it('1 should be 2', createTest(1, `2`, (k, v) => 2)); | ||
| it('{} should be {}', createTest({}, '{}')); | ||
| it('{a:undefined} should be {}', createTest({ | ||
| a: undefined | ||
| }, '{}')); | ||
| it('{a:null} should be {"a":null}', createTest({ | ||
| a: null | ||
| }, '{"a":null}')); | ||
| it('{a:undefined} should be {"a":1}', createTest({ | ||
| a: undefined | ||
| }, '{"a":1}', (k, v) => { | ||
| if (k) { | ||
| expect(k).to.be('a'); | ||
| } | ||
| return k ? 1 : v; | ||
| })); | ||
| it('{a:1,b,2} should be {"b":2}', createTest({ | ||
| a: 1, | ||
| b: 2 | ||
| }, '{"b":2}', ['b'])); | ||
| it('{a:1} should be {"a":1}', createTest({ | ||
| a: 1 | ||
| }, '{"a":1}')); | ||
| it('{a:function(){}} should be {}', createTest({ | ||
| a: function() {} | ||
| }, '{}')); | ||
| it('[function(){}] should be [null]', createTest([function() {}], '[null]')); | ||
| it('{a:date} should be {"a":date.toJSON()}', createTest({ | ||
| a: date | ||
| }, `{"a":"${date.toJSON()}"}`)); | ||
| it('({a:1,b:{c:2}}) should be {"a":1,"b":{"c":2}}', createTest(({ | ||
| a: 1, | ||
| b: { | ||
| c: 2 | ||
| } | ||
| }), '{"a":1,"b":{"c":2}}')); | ||
| it('{a:[1], "b": 2} should be {"a":[1],"b":2}', createTest({ | ||
| a: [1], | ||
| b: 2 | ||
| }, '{"a":[1],"b":2}')); | ||
| it('[] should be []', createTest([], '[]')); | ||
| it('[[[]],[[]]] should be [[[]],[[]]]', createTest([ | ||
| [ | ||
| [] | ||
| ], | ||
| [ | ||
| [] | ||
| ] | ||
| ], '[[[]],[[]]]')); | ||
| it('[1, undefined, 2] should be [1,null,2]', createTest([1, undefined, 2], '[1,null,2]')); | ||
| it(`[1,'a'] should be [1,"a"]`, createTest([1, 'a'], '[1,"a"]')); | ||
| it('Promise(1) should be 1', createTest(Promise.resolve(1), '1')); | ||
| it('Promise(Promise(1)) should be 1', createTest(Promise.resolve(Promise.resolve(1)), '1')); | ||
| it('{a:Promise(1)} should be {"a":1}', createTest({ | ||
| a: Promise.resolve(1) | ||
| }, '{"a":1}')); | ||
| it('ReadableStream(1) should be [1]', createTest(ReadableStream(1), '[1]')); | ||
| it('{a:ReadableStream(1,2,3)} should be {"a":[1,2,3]}', createTest({ | ||
| a: ReadableStream(1, 2, 3) | ||
| }, '{"a":[1,2,3]}')); | ||
| it(`ReadableStream('a', 'b', 'c') should be "abc"`, createTest(ReadableStream('a', 'b', 'c'), '"abc"')); | ||
| it(`ReadableStream({}, 'a', undefined, 'c') should be [{},"a",null,"c"]`, createTest(ReadableStream({}, 'a', undefined, 'c'), '[{},"a",null,"c"]')); | ||
| it(`{ a: ReadableStream({name: 'name', date: date }) } should be {"a":[{"name":"name","date":"${date.toJSON()}"}]}`, createTest({ | ||
| a: ReadableStream({ | ||
| name: 'name', | ||
| date: date | ||
| }) | ||
| }, `{"a":[{"name":"name","date":"${date.toJSON()}"}]}`)); | ||
| it(`{ a: ReadableStream({name: 'name', arr: [], date: date }) } should be {"a":[{"name":"name","arr":[],"date":"${date.toJSON()}"}]}`, createTest({ | ||
| a: ReadableStream({ | ||
| name: 'name', | ||
| arr: [], | ||
| date: date | ||
| }) | ||
| }, `{"a":[{"name":"name","arr":[],"date":"${date.toJSON()}"}]}`)); | ||
| describe('circular structure', function() { | ||
| let circularData0 = {}; | ||
| circularData0.a = circularData0; | ||
| it(`{ a: a } should be {"a":{"$ref":"$"}}`, createTest(circularData0, `{"a":{"$ref":"$"}}`)); | ||
| let circularData1 = {}; | ||
| circularData1.a = circularData1; | ||
| circularData1.b = [circularData1, { | ||
| a: circularData1 | ||
| }] | ||
| circularData1.b[3] = ReadableStream(circularData1.b[1]); | ||
| it('{a: a, b: [a, { a: a },,ReadableStream(b.1)]} should be {"a":{"$ref":"$"},"b":[{"$ref":"$"},{"a":{"$ref":"$"}},null,[{"$ref":"$[\\"b\\"][1]"}]]}', createTest(circularData1, '{"a":{"$ref":"$"},"b":[{"$ref":"$"},{"a":{"$ref":"$"}},null,[{"$ref":"$[\\"b\\"][1]"}]]}')); | ||
| let circularData2 = {}; | ||
| let data2 = { | ||
| a: 'deep' | ||
| }; | ||
| circularData2.a = Promise.resolve({ | ||
| b: data2 | ||
| }); | ||
| circularData2.b = data2; | ||
| it(`{ a: Promise({ b: { a: 'deep' } }), b: a.b } should be {"a":{"b":{"a":"deep"}},"b":{"$ref":"$[\\"a\\"][\\"b\\"]"}}`, createTest(circularData2, `{"a":{"b":{"a":"deep"}},"b":{"$ref":"$[\\"a\\"][\\"b\\"]"}}`)); | ||
| }); | ||
| describe('disable circular', () => { | ||
| let el = { foo: 'bar' }; | ||
| const arr = [el, el]; | ||
| it(`[{"foo":"bar"},{"foo":"bar"}] should be [{"foo":"bar"},{"foo":"bar"}]`, createTest(arr, `[{"foo":"bar"},{"foo":"bar"}]`, undefined, 2, true)); | ||
| }); | ||
| }); |
-10
| 'use strict'; | ||
| module.exports = { | ||
| isReadableStream: function (obj) { | ||
| return obj && | ||
| typeof obj.pipe === 'function' && | ||
| typeof obj._read === 'function' && | ||
| typeof obj._readableState === 'object'; | ||
| } | ||
| }; |
New alerts
Major refactor
Supply chain riskPackage has recently undergone a major refactor. It may be unstable or indicate significant internal changes. Use caution when updating to versions that include significant changes.
Found 1 instance in 1 package
Long strings
Supply chain riskContains long string literals, which may be a sign of obfuscated or packed code.
Found 1 instance in 1 package
URL strings
Supply chain riskPackage contains fragments of external URLs or IP addresses, which the package may be accessing at runtime.
Found 1 instance in 1 package
Fixed alerts
No bug tracker
MaintenancePackage does not have a linked bug tracker in package.json.
Found 1 instance in 1 package
Improved metrics
- Total package byte prevSize
168007
604.99%- Number of package files
11
22.22%- Lines of code
1887
339.86%- Number of low maintenance alerts
0
-100%- Number of lines in readme file
177
40.48%Worsened metrics
- Dev dependency count
21
425%- Number of low supply chain risk alerts
5
Infinity%- Number of medium supply chain risk alerts
1
Infinity%No dependency changes