Huge News!Announcing our $40M Series B led by Abstract Ventures.Learn More →
pbf - npm Package Compare versions
Comparing version 3.3.0 to 4.0.0
288
compile.js
@@ -1,28 +0,21 @@ | ||
| 'use strict'; | ||
| module.exports = compile; | ||
| import {readFileSync} from 'fs'; | ||
| var version = require('./package.json').version; | ||
| const version = JSON.parse(readFileSync(new URL('package.json', import.meta.url))).version; | ||
| function compile(proto) { | ||
| var code = 'var exports = {};\n'; | ||
| code += compileRaw(proto) + '\n'; | ||
| code += 'return exports;\n'; | ||
| return new Function(code)(); | ||
| export function compile(proto) { | ||
| return new Function(`const exports = {};\n${compileRaw(proto, {legacy: true})}\nreturn exports;`)(); | ||
| } | ||
| compile.raw = compileRaw; | ||
| function compileRaw(proto, options) { | ||
| var pre = '\'use strict\'; // code generated by pbf v' + version + '\n'; | ||
| var context = buildDefaults(buildContext(proto, null), proto.syntax); | ||
| return pre + writeContext(context, options || {}); | ||
| export function compileRaw(proto, options = {}) { | ||
| const context = buildDefaults(buildContext(proto, null), proto.syntax); | ||
| return `${options.dev ? '' : `// code generated by pbf v${version}\n`}${writeContext(context, options)}`; | ||
| } | ||
| function writeContext(ctx, options) { | ||
| var code = ''; | ||
| let code = ''; | ||
| if (ctx._proto.fields) code += writeMessage(ctx, options); | ||
| if (ctx._proto.values) code += writeEnum(ctx, options); | ||
| for (var i = 0; i < ctx._children.length; i++) { | ||
| for (let i = 0; i < ctx._children.length; i++) { | ||
| code += writeContext(ctx._children[i], options); | ||
@@ -34,53 +27,48 @@ } | ||
| function writeMessage(ctx, options) { | ||
| var name = ctx._name; | ||
| var fields = ctx._proto.fields; | ||
| var numRepeated = 0; | ||
| const fields = ctx._proto.fields; | ||
| var code = '\n// ' + name + ' ========================================\n\n'; | ||
| let code = '\n'; | ||
| if (!options.noRead || !options.noWrite) { | ||
| code += compileExport(ctx, options) + ' {};\n\n'; | ||
| } | ||
| if (!options.noRead) { | ||
| code += name + '.read = function (pbf, end) {\n'; | ||
| code += ' return pbf.readFields(' + name + '._readField, ' + compileDest(ctx) + ', end);\n'; | ||
| code += '};\n'; | ||
| code += name + '._readField = function (tag, obj, pbf) {\n'; | ||
| const readName = `read${ctx._name}`; | ||
| code += | ||
| `${writeFunctionExport(options, readName)}function ${readName}(pbf, end) { | ||
| return pbf.readFields(${readName}Field, ${compileDest(ctx)}, end); | ||
| } | ||
| function ${readName}Field(tag, obj, pbf) { | ||
| `; | ||
| for (let i = 0; i < fields.length; i++) { | ||
| const field = fields[i]; | ||
| const {type, name, repeated, oneof, tag} = field; | ||
| const readCode = compileFieldRead(ctx, field); | ||
| const packed = willSupportPacked(ctx, field); | ||
| for (var i = 0; i < fields.length; i++) { | ||
| var field = fields[i]; | ||
| var readCode = compileFieldRead(ctx, field); | ||
| var packed = willSupportPacked(ctx, field); | ||
| code += ' ' + (i ? 'else if' : 'if') + | ||
| ' (tag === ' + field.tag + ') ' + | ||
| (field.type === 'map' ? ' { ' : '') + | ||
| ( | ||
| field.type === 'map' ? compileMapRead(readCode, field.name, numRepeated++) : | ||
| field.repeated && !packed ? 'obj.' + field.name + '.push(' + readCode + ')' : | ||
| field.repeated && packed ? readCode : 'obj.' + field.name + ' = ' + readCode | ||
| ); | ||
| let fieldRead = | ||
| type === 'map' ? compileMapRead(readCode, name) : | ||
| repeated ? (packed ? readCode : `obj.${name}.push(${readCode})`) : | ||
| `obj.${name} = ${readCode}`; | ||
| if (field.oneof) { | ||
| code += ', obj.' + field.oneof + ' = ' + JSON.stringify(field.name); | ||
| if (oneof) { | ||
| fieldRead += `; obj.${oneof} = ${JSON.stringify(name)}`; | ||
| } | ||
| code += ';' + (field.type === 'map' ? ' }' : '') + '\n'; | ||
| fieldRead = type === 'map' || oneof ? `{ ${fieldRead}; }` : `${fieldRead};`; | ||
| code += | ||
| ` ${i ? 'else ' : ''}if (tag === ${tag}) ${fieldRead}\n`; | ||
| } | ||
| code += '};\n'; | ||
| code += '}\n'; | ||
| } | ||
| if (!options.noWrite) { | ||
| code += name + '.write = function (obj, pbf) {\n'; | ||
| numRepeated = 0; | ||
| for (i = 0; i < fields.length; i++) { | ||
| field = fields[i]; | ||
| var writeCode = field.repeated && !isPacked(field) ? | ||
| compileRepeatedWrite(ctx, field, numRepeated++) : | ||
| field.type === 'map' ? compileMapWrite(ctx, field, numRepeated++) : | ||
| compileFieldWrite(ctx, field, 'obj.' + field.name); | ||
| const writeName = `write${ctx._name}`; | ||
| code += `${writeFunctionExport(options, writeName)}function ${writeName}(obj, pbf) {\n`; | ||
| for (const field of fields) { | ||
| const writeCode = | ||
| field.repeated && !isPacked(field) ? compileRepeatedWrite(ctx, field) : | ||
| field.type === 'map' ? compileMapWrite(ctx, field) : compileFieldWrite(ctx, field, `obj.${field.name}`); | ||
| code += getDefaultWriteTest(ctx, field); | ||
| code += writeCode + ';\n'; | ||
| code += `${writeCode};\n`; | ||
| } | ||
| code += '};\n'; | ||
| code += '}\n'; | ||
| } | ||
@@ -90,6 +78,10 @@ return code; | ||
| function writeFunctionExport({legacy}, name) { | ||
| return legacy ? `exports.${name} = ${name};\n` : 'export '; | ||
| } | ||
| function getEnumValues(ctx) { | ||
| var enums = {}; | ||
| var ids = Object.keys(ctx._proto.values); | ||
| for (var i = 0; i < ids.length; i++) { | ||
| const enums = {}; | ||
| const ids = Object.keys(ctx._proto.values); | ||
| for (let i = 0; i < ids.length; i++) { | ||
| enums[ids[i]] = ctx._proto.values[ids[i]].value; | ||
@@ -100,20 +92,15 @@ } | ||
| function writeEnum(ctx, options) { | ||
| return '\n' + compileExport(ctx, options) + ' ' + | ||
| JSON.stringify(getEnumValues(ctx), null, 4) + ';\n'; | ||
| function writeEnum(ctx, {legacy}) { | ||
| const enums = JSON.stringify(getEnumValues(ctx), null, 4); | ||
| const name = ctx._name; | ||
| return `\n${legacy ? `const ${name} = exports.${name}` : `export const ${name}`} = ${enums};\n`; | ||
| } | ||
| function compileExport(ctx, options) { | ||
| var exportsVar = options.exports || 'exports'; | ||
| return (ctx._root ? 'var ' + ctx._name + ' = ' + exportsVar + '.' : '') + ctx._name + ' ='; | ||
| } | ||
| function compileDest(ctx) { | ||
| var props = {}; | ||
| for (var i = 0; i < ctx._proto.fields.length; i++) { | ||
| var field = ctx._proto.fields[i]; | ||
| props[field.name + ': ' + JSON.stringify(ctx._defaults[field.name])] = true; | ||
| if (field.oneof) props[field.oneof + ': undefined'] = true; | ||
| const props = new Set(); | ||
| for (const {name, oneof} of ctx._proto.fields) { | ||
| props.add(`${name}: ${JSON.stringify(ctx._defaults[name])}`); | ||
| if (oneof) props.add(`${oneof }: undefined`); | ||
| } | ||
| return '{' + Object.keys(props).join(', ') + '}'; | ||
| return `{${[...props].join(', ')}}`; | ||
| } | ||
@@ -129,5 +116,4 @@ | ||
| } | ||
| var path = field.type.split('.'); | ||
| return path.reduce(function(ctx, name) { return ctx && ctx[name]; }, ctx); | ||
| const path = field.type.split('.'); | ||
| return path.reduce((ctx, name) => ctx && ctx[name], ctx); | ||
| } | ||
@@ -157,17 +143,17 @@ | ||
| function compileFieldRead(ctx, field) { | ||
| var type = getType(ctx, field); | ||
| const type = getType(ctx, field); | ||
| if (type) { | ||
| if (type._proto.fields) return type._name + '.read(pbf, pbf.readVarint() + pbf.pos)'; | ||
| if (!isEnum(type)) throw new Error('Unexpected type: ' + type._name); | ||
| if (type._proto.fields) return `read${type._name}(pbf, pbf.readVarint() + pbf.pos)`; | ||
| if (!isEnum(type)) throw new Error(`Unexpected type: ${type._name}`); | ||
| } | ||
| var fieldType = isEnum(type) ? 'enum' : field.type; | ||
| const fieldType = isEnum(type) ? 'enum' : field.type; | ||
| var prefix = 'pbf.read'; | ||
| var signed = fieldType === 'int32' || fieldType === 'int64' ? 'true' : ''; | ||
| var suffix = '(' + signed + ')'; | ||
| let prefix = 'pbf.read'; | ||
| const signed = fieldType === 'int32' || fieldType === 'int64' ? 'true' : ''; | ||
| let suffix = `(${signed})`; | ||
| if (willSupportPacked(ctx, field)) { | ||
| prefix += 'Packed'; | ||
| suffix = '(obj.' + field.name + (signed ? ', ' + signed : '') + ')'; | ||
| suffix = `(obj.${field.name}${signed ? `, ${signed}` : ''})`; | ||
| } | ||
@@ -180,6 +166,6 @@ | ||
| switch (fieldType) { | ||
| case 'string': return prefix + 'String' + suffix; | ||
| case 'float': return prefix + 'Float' + suffix; | ||
| case 'double': return prefix + 'Double' + suffix; | ||
| case 'bool': return prefix + 'Boolean' + suffix; | ||
| case 'string': return `${prefix}String${suffix}`; | ||
| case 'float': return `${prefix}Float${suffix}`; | ||
| case 'double': return `${prefix}Double${suffix}`; | ||
| case 'bool': return `${prefix}Boolean${suffix}`; | ||
| case 'enum': | ||
@@ -189,11 +175,11 @@ case 'uint32': | ||
| case 'int32': | ||
| case 'int64': return prefix + 'Varint' + suffix; | ||
| case 'int64': return `${prefix}Varint${suffix}`; | ||
| case 'sint32': | ||
| case 'sint64': return prefix + 'SVarint' + suffix; | ||
| case 'fixed32': return prefix + 'Fixed32' + suffix; | ||
| case 'fixed64': return prefix + 'Fixed64' + suffix; | ||
| case 'sfixed32': return prefix + 'SFixed32' + suffix; | ||
| case 'sfixed64': return prefix + 'SFixed64' + suffix; | ||
| case 'bytes': return prefix + 'Bytes' + suffix; | ||
| default: throw new Error('Unexpected type: ' + field.type); | ||
| case 'sint64': return `${prefix}SVarint${suffix}`; | ||
| case 'fixed32': return `${prefix}Fixed32${suffix}`; | ||
| case 'fixed64': return `${prefix}Fixed64${suffix}`; | ||
| case 'sfixed32': return `${prefix}SFixed32${suffix}`; | ||
| case 'sfixed64': return `${prefix}SFixed64${suffix}`; | ||
| case 'bytes': return `${prefix}Bytes${suffix}`; | ||
| default: throw new Error(`Unexpected type: ${field.type}`); | ||
| } | ||
@@ -203,3 +189,3 @@ } | ||
| function compileFieldWrite(ctx, field, name) { | ||
| var prefix = 'pbf.write'; | ||
| let prefix = 'pbf.write'; | ||
| if (isPacked(field)) prefix += 'Packed'; | ||
@@ -209,21 +195,21 @@ | ||
| if (field.type === 'float' || field.type === 'double') { | ||
| name = 'parseFloat(' + name + ')'; | ||
| name = `parseFloat(${name})`; | ||
| } else { | ||
| name = 'parseInt(' + name + ', 10)'; | ||
| name = `parseInt(${name}, 10)`; | ||
| } | ||
| } | ||
| var postfix = (isPacked(field) ? '' : 'Field') + '(' + field.tag + ', ' + name + ')'; | ||
| const postfix = `${isPacked(field) ? '' : 'Field'}(${field.tag}, ${name})`; | ||
| var type = getType(ctx, field); | ||
| const type = getType(ctx, field); | ||
| if (type) { | ||
| if (type._proto.fields) return prefix + 'Message(' + field.tag + ', ' + type._name + '.write, ' + name + ')'; | ||
| if (type._proto.values) return prefix + 'Varint' + postfix; | ||
| throw new Error('Unexpected type: ' + type._name); | ||
| if (type._proto.fields) return `${prefix}Message(${field.tag}, write${type._name}, ${name})`; | ||
| if (type._proto.values) return `${prefix}Varint${postfix}`; | ||
| throw new Error(`Unexpected type: ${type._name}`); | ||
| } | ||
| switch (field.type) { | ||
| case 'string': return prefix + 'String' + postfix; | ||
| case 'float': return prefix + 'Float' + postfix; | ||
| case 'double': return prefix + 'Double' + postfix; | ||
| case 'bool': return prefix + 'Boolean' + postfix; | ||
| case 'string': return `${prefix}String${postfix}`; | ||
| case 'float': return `${prefix}Float${postfix}`; | ||
| case 'double': return `${prefix}Double${postfix}`; | ||
| case 'bool': return `${prefix}Boolean${postfix}`; | ||
| case 'enum': | ||
@@ -233,34 +219,32 @@ case 'uint32': | ||
| case 'int32': | ||
| case 'int64': return prefix + 'Varint' + postfix; | ||
| case 'int64': return `${prefix}Varint${postfix}`; | ||
| case 'sint32': | ||
| case 'sint64': return prefix + 'SVarint' + postfix; | ||
| case 'fixed32': return prefix + 'Fixed32' + postfix; | ||
| case 'fixed64': return prefix + 'Fixed64' + postfix; | ||
| case 'sfixed32': return prefix + 'SFixed32' + postfix; | ||
| case 'sfixed64': return prefix + 'SFixed64' + postfix; | ||
| case 'bytes': return prefix + 'Bytes' + postfix; | ||
| default: throw new Error('Unexpected type: ' + field.type); | ||
| case 'sint64': return `${prefix}SVarint${postfix}`; | ||
| case 'fixed32': return `${prefix}Fixed32${postfix}`; | ||
| case 'fixed64': return `${prefix}Fixed64${postfix}`; | ||
| case 'sfixed32': return `${prefix}SFixed32${postfix}`; | ||
| case 'sfixed64': return `${prefix}SFixed64${postfix}`; | ||
| case 'bytes': return `${prefix}Bytes${postfix}`; | ||
| default: throw new Error(`Unexpected type: ${field.type}`); | ||
| } | ||
| } | ||
| function compileMapRead(readCode, name, numRepeated) { | ||
| return (numRepeated ? '' : 'var ') + 'entry = ' + readCode + '; obj.' + name + '[entry.key] = entry.value'; | ||
| function compileMapRead(readCode, name) { | ||
| return `const {key, value} = ${readCode}; obj.${name}[key] = value`; | ||
| } | ||
| function compileRepeatedWrite(ctx, field, numRepeated) { | ||
| return 'for (' + (numRepeated ? '' : 'var ') + | ||
| 'i = 0; i < obj.' + field.name + '.length; i++) ' + | ||
| compileFieldWrite(ctx, field, 'obj.' + field.name + '[i]'); | ||
| function compileRepeatedWrite(ctx, field) { | ||
| return `for (const item of obj.${field.name}) ${ | ||
| compileFieldWrite(ctx, field, 'item')}`; | ||
| } | ||
| function compileMapWrite(ctx, field, numRepeated) { | ||
| var name = 'obj.' + field.name; | ||
| function compileMapWrite(ctx, field) { | ||
| const name = `obj.${field.name}`; | ||
| return 'for (' + (numRepeated ? '' : 'var ') + | ||
| 'i in ' + name + ') if (Object.prototype.hasOwnProperty.call(' + name + ', i)) ' + | ||
| compileFieldWrite(ctx, field, '{ key: i, value: ' + name + '[i] }'); | ||
| return `for (const key of Object.keys(${name})) ${ | ||
| compileFieldWrite(ctx, field, `{key, value: ${name}[key]}`)}`; | ||
| } | ||
| function getMapMessageName(tag) { | ||
| return '_FieldEntry' + tag; | ||
| return `_FieldEntry${tag}`; | ||
| } | ||
@@ -270,5 +254,5 @@ | ||
| return { | ||
| name: name, | ||
| type: type, | ||
| tag: tag, | ||
| name, | ||
| type, | ||
| tag, | ||
| map: null, | ||
@@ -296,3 +280,3 @@ oneof: null, | ||
| function buildContext(proto, parent) { | ||
| var obj = Object.create(parent); | ||
| const obj = Object.create(parent); | ||
| obj._proto = proto; | ||
@@ -306,6 +290,4 @@ obj._children = []; | ||
| if (parent._name) { | ||
| obj._root = false; | ||
| obj._name = parent._name + '.' + proto.name; | ||
| obj._name = parent._name + proto.name; | ||
| } else { | ||
| obj._root = true; | ||
| obj._name = proto.name; | ||
@@ -315,11 +297,11 @@ } | ||
| for (var i = 0; proto.enums && i < proto.enums.length; i++) { | ||
| for (let i = 0; proto.enums && i < proto.enums.length; i++) { | ||
| obj._children.push(buildContext(proto.enums[i], obj)); | ||
| } | ||
| for (i = 0; proto.messages && i < proto.messages.length; i++) { | ||
| for (let i = 0; proto.messages && i < proto.messages.length; i++) { | ||
| obj._children.push(buildContext(proto.messages[i], obj)); | ||
| } | ||
| for (i = 0; proto.fields && i < proto.fields.length; i++) { | ||
| for (let i = 0; proto.fields && i < proto.fields.length; i++) { | ||
| if (proto.fields[i].type === 'map') { | ||
@@ -336,5 +318,5 @@ obj._children.push(buildContext(getMapMessage(proto.fields[i]), obj)); | ||
| if (field.repeated) return []; | ||
| var convertToStringIfNeeded = function(val) { return val; }; | ||
| let convertToStringIfNeeded = function (val) { return val; }; | ||
| if (fieldShouldUseStringAsNumber(field)) { | ||
| convertToStringIfNeeded = function(val) { return val.toString(); }; | ||
| convertToStringIfNeeded = function (val) { return val.toString(); }; | ||
| } | ||
@@ -363,3 +345,3 @@ | ||
| function willSupportPacked(ctx, field) { | ||
| var fieldType = isEnum(getType(ctx, field)) ? 'enum' : field.type; | ||
| const fieldType = isEnum(getType(ctx, field)) ? 'enum' : field.type; | ||
@@ -399,8 +381,8 @@ switch (field.repeated && fieldType) { | ||
| function setDefaultValue(ctx, field, syntax) { | ||
| var options = field.options; | ||
| var type = getType(ctx, field); | ||
| var enumValues = type && type._proto.values && getEnumValues(type); | ||
| const options = field.options; | ||
| const type = getType(ctx, field); | ||
| const enumValues = type && type._proto.values && getEnumValues(type); | ||
| // Proto3 does not support overriding defaults | ||
| var explicitDefault = syntax < 3 ? options.default : undefined; | ||
| const explicitDefault = syntax < 3 ? options.default : undefined; | ||
@@ -417,5 +399,5 @@ // Set default for enum values | ||
| function buildDefaults(ctx, syntax) { | ||
| var proto = ctx._proto; | ||
| const proto = ctx._proto; | ||
| for (var i = 0; i < ctx._children.length; i++) { | ||
| for (let i = 0; i < ctx._children.length; i++) { | ||
| buildDefaults(ctx._children[i], syntax); | ||
@@ -425,3 +407,3 @@ } | ||
| if (proto.fields) { | ||
| for (i = 0; i < proto.fields.length; i++) { | ||
| for (let i = 0; i < proto.fields.length; i++) { | ||
| setPackedOption(ctx, proto.fields[i], syntax); | ||
@@ -436,16 +418,16 @@ setDefaultValue(ctx, proto.fields[i], syntax); | ||
| function getDefaultWriteTest(ctx, field) { | ||
| var def = ctx._defaults[field.name]; | ||
| var type = getType(ctx, field); | ||
| var code = ' if (obj.' + field.name; | ||
| const def = ctx._defaults[field.name]; | ||
| const type = getType(ctx, field); | ||
| let code = ` if (obj.${field.name}`; | ||
| if (!field.repeated && (!type || !type._proto.fields)) { | ||
| if (def === undefined || def) { | ||
| code += ' != undefined'; | ||
| if (def === undefined || def || field.oneof) { | ||
| code += ' != null'; | ||
| } | ||
| if (def) { | ||
| code += ' && obj.' + field.name + ' !== ' + JSON.stringify(def); | ||
| code += ` && obj.${field.name} !== ${JSON.stringify(def)}`; | ||
| } | ||
| } | ||
| return code + ') '; | ||
| return `${code}) `; | ||
| } | ||
@@ -452,0 +434,0 @@ |
@@ -1,41 +0,43 @@ | ||
| (function(f){if(typeof exports==="object"&&typeof module!=="undefined"){module.exports=f()}else if(typeof define==="function"&&define.amd){define([],f)}else{var g;if(typeof window!=="undefined"){g=window}else if(typeof global!=="undefined"){g=global}else if(typeof self!=="undefined"){g=self}else{g=this}g.Pbf = f()}})(function(){var define,module,exports;return (function(){function r(e,n,t){function o(i,f){if(!n[i]){if(!e[i]){var c="function"==typeof require&&require;if(!f&&c)return c(i,!0);if(u)return u(i,!0);var a=new Error("Cannot find module '"+i+"'");throw a.code="MODULE_NOT_FOUND",a}var p=n[i]={exports:{}};e[i][0].call(p.exports,function(r){var n=e[i][1][r];return o(n||r)},p,p.exports,r,e,n,t)}return n[i].exports}for(var u="function"==typeof require&&require,i=0;i<t.length;i++)o(t[i]);return o}return r})()({1:[function(require,module,exports){ | ||
| 'use strict'; | ||
| (function (global, factory) { | ||
| typeof exports === 'object' && typeof module !== 'undefined' ? module.exports = factory() : | ||
| typeof define === 'function' && define.amd ? define(factory) : | ||
| (global = typeof globalThis !== 'undefined' ? globalThis : global || self, global.Pbf = factory()); | ||
| })(this, (function () { 'use strict'; | ||
| module.exports = Pbf; | ||
| const SHIFT_LEFT_32 = (1 << 16) * (1 << 16); | ||
| const SHIFT_RIGHT_32 = 1 / SHIFT_LEFT_32; | ||
| var ieee754 = require('ieee754'); | ||
| function Pbf(buf) { | ||
| this.buf = ArrayBuffer.isView && ArrayBuffer.isView(buf) ? buf : new Uint8Array(buf || 0); | ||
| this.pos = 0; | ||
| this.type = 0; | ||
| this.length = this.buf.length; | ||
| } | ||
| Pbf.Varint = 0; // varint: int32, int64, uint32, uint64, sint32, sint64, bool, enum | ||
| Pbf.Fixed64 = 1; // 64-bit: double, fixed64, sfixed64 | ||
| Pbf.Bytes = 2; // length-delimited: string, bytes, embedded messages, packed repeated fields | ||
| Pbf.Fixed32 = 5; // 32-bit: float, fixed32, sfixed32 | ||
| var SHIFT_LEFT_32 = (1 << 16) * (1 << 16), | ||
| SHIFT_RIGHT_32 = 1 / SHIFT_LEFT_32; | ||
| // Threshold chosen based on both benchmarking and knowledge about browser string | ||
| // data structures (which currently switch structure types at 12 bytes or more) | ||
| var TEXT_DECODER_MIN_LENGTH = 12; | ||
| var utf8TextDecoder = typeof TextDecoder === 'undefined' ? null : new TextDecoder('utf-8'); | ||
| const TEXT_DECODER_MIN_LENGTH = 12; | ||
| const utf8TextDecoder = typeof TextDecoder === 'undefined' ? null : new TextDecoder('utf-8'); | ||
| Pbf.prototype = { | ||
| const PBF_VARINT = 0; // varint: int32, int64, uint32, uint64, sint32, sint64, bool, enum | ||
| const PBF_FIXED64 = 1; // 64-bit: double, fixed64, sfixed64 | ||
| const PBF_BYTES = 2; // length-delimited: string, bytes, embedded messages, packed repeated fields | ||
| const PBF_FIXED32 = 5; // 32-bit: float, fixed32, sfixed32 | ||
| destroy: function() { | ||
| this.buf = null; | ||
| }, | ||
| class Pbf { | ||
| /** | ||
| * @param {Uint8Array | ArrayBuffer} buf | ||
| */ | ||
| constructor(buf) { | ||
| this.buf = ArrayBuffer.isView && ArrayBuffer.isView(buf) ? buf : new Uint8Array(buf || 0); | ||
| this.dataView = new DataView(this.buf.buffer); | ||
| this.pos = 0; | ||
| this.type = 0; | ||
| this.length = this.buf.length; | ||
| } | ||
| // === READING ================================================================= | ||
| readFields: function(readField, result, end) { | ||
| end = end || this.length; | ||
| /** | ||
| * @template T | ||
| * @param {(tag: number, result: T, pbf: Pbf) => void} readField | ||
| * @param {T} result | ||
| * @param {number} [end] | ||
| */ | ||
| readFields(readField, result, end = this.length) { | ||
| while (this.pos < end) { | ||
| var val = this.readVarint(), | ||
| const val = this.readVarint(), | ||
| tag = val >> 3, | ||
@@ -50,49 +52,57 @@ startPos = this.pos; | ||
| return result; | ||
| }, | ||
| } | ||
| readMessage: function(readField, result) { | ||
| /** | ||
| * @template T | ||
| * @param {(tag: number, result: T, pbf: Pbf) => void} readField | ||
| * @param {T} result | ||
| */ | ||
| readMessage(readField, result) { | ||
| return this.readFields(readField, result, this.readVarint() + this.pos); | ||
| }, | ||
| } | ||
| readFixed32: function() { | ||
| var val = readUInt32(this.buf, this.pos); | ||
| readFixed32() { | ||
| const val = this.dataView.getUint32(this.pos, true); | ||
| this.pos += 4; | ||
| return val; | ||
| }, | ||
| } | ||
| readSFixed32: function() { | ||
| var val = readInt32(this.buf, this.pos); | ||
| readSFixed32() { | ||
| const val = this.dataView.getInt32(this.pos, true); | ||
| this.pos += 4; | ||
| return val; | ||
| }, | ||
| } | ||
| // 64-bit int handling is based on github.com/dpw/node-buffer-more-ints (MIT-licensed) | ||
| readFixed64: function() { | ||
| var val = readUInt32(this.buf, this.pos) + readUInt32(this.buf, this.pos + 4) * SHIFT_LEFT_32; | ||
| readFixed64() { | ||
| const val = this.dataView.getUint32(this.pos, true) + this.dataView.getUint32(this.pos + 4, true) * SHIFT_LEFT_32; | ||
| this.pos += 8; | ||
| return val; | ||
| }, | ||
| } | ||
| readSFixed64: function() { | ||
| var val = readUInt32(this.buf, this.pos) + readInt32(this.buf, this.pos + 4) * SHIFT_LEFT_32; | ||
| readSFixed64() { | ||
| const val = this.dataView.getUint32(this.pos, true) + this.dataView.getInt32(this.pos + 4, true) * SHIFT_LEFT_32; | ||
| this.pos += 8; | ||
| return val; | ||
| }, | ||
| } | ||
| readFloat: function() { | ||
| var val = ieee754.read(this.buf, this.pos, true, 23, 4); | ||
| readFloat() { | ||
| const val = this.dataView.getFloat32(this.pos, true); | ||
| this.pos += 4; | ||
| return val; | ||
| }, | ||
| } | ||
| readDouble: function() { | ||
| var val = ieee754.read(this.buf, this.pos, true, 52, 8); | ||
| readDouble() { | ||
| const val = this.dataView.getFloat64(this.pos, true); | ||
| this.pos += 8; | ||
| return val; | ||
| }, | ||
| } | ||
| readVarint: function(isSigned) { | ||
| var buf = this.buf, | ||
| val, b; | ||
| /** | ||
| * @param {boolean} [isSigned] | ||
| */ | ||
| readVarint(isSigned) { | ||
| const buf = this.buf; | ||
| let val, b; | ||
@@ -106,20 +116,20 @@ b = buf[this.pos++]; val = b & 0x7f; if (b < 0x80) return val; | ||
| return readVarintRemainder(val, isSigned, this); | ||
| }, | ||
| } | ||
| readVarint64: function() { // for compatibility with v2.0.1 | ||
| readVarint64() { // for compatibility with v2.0.1 | ||
| return this.readVarint(true); | ||
| }, | ||
| } | ||
| readSVarint: function() { | ||
| var num = this.readVarint(); | ||
| readSVarint() { | ||
| const num = this.readVarint(); | ||
| return num % 2 === 1 ? (num + 1) / -2 : num / 2; // zigzag encoding | ||
| }, | ||
| } | ||
| readBoolean: function() { | ||
| readBoolean() { | ||
| return Boolean(this.readVarint()); | ||
| }, | ||
| } | ||
| readString: function() { | ||
| var end = this.readVarint() + this.pos; | ||
| var pos = this.pos; | ||
| readString() { | ||
| const end = this.readVarint() + this.pos; | ||
| const pos = this.pos; | ||
| this.pos = end; | ||
@@ -129,98 +139,101 @@ | ||
| // longer strings are fast with the built-in browser TextDecoder API | ||
| return readUtf8TextDecoder(this.buf, pos, end); | ||
| return utf8TextDecoder.decode(this.buf.subarray(pos, end)); | ||
| } | ||
| // short strings are fast with our custom implementation | ||
| return readUtf8(this.buf, pos, end); | ||
| }, | ||
| } | ||
| readBytes: function() { | ||
| var end = this.readVarint() + this.pos, | ||
| readBytes() { | ||
| const end = this.readVarint() + this.pos, | ||
| buffer = this.buf.subarray(this.pos, end); | ||
| this.pos = end; | ||
| return buffer; | ||
| }, | ||
| } | ||
| // verbose for performance reasons; doesn't affect gzipped size | ||
| readPackedVarint: function(arr, isSigned) { | ||
| if (this.type !== Pbf.Bytes) return arr.push(this.readVarint(isSigned)); | ||
| var end = readPackedEnd(this); | ||
| arr = arr || []; | ||
| /** | ||
| * @param {number[]} [arr] | ||
| * @param {boolean} [isSigned] | ||
| */ | ||
| readPackedVarint(arr = [], isSigned) { | ||
| const end = this.readPackedEnd(); | ||
| while (this.pos < end) arr.push(this.readVarint(isSigned)); | ||
| return arr; | ||
| }, | ||
| readPackedSVarint: function(arr) { | ||
| if (this.type !== Pbf.Bytes) return arr.push(this.readSVarint()); | ||
| var end = readPackedEnd(this); | ||
| arr = arr || []; | ||
| } | ||
| /** @param {number[]} [arr] */ | ||
| readPackedSVarint(arr = []) { | ||
| const end = this.readPackedEnd(); | ||
| while (this.pos < end) arr.push(this.readSVarint()); | ||
| return arr; | ||
| }, | ||
| readPackedBoolean: function(arr) { | ||
| if (this.type !== Pbf.Bytes) return arr.push(this.readBoolean()); | ||
| var end = readPackedEnd(this); | ||
| arr = arr || []; | ||
| } | ||
| /** @param {boolean[]} [arr] */ | ||
| readPackedBoolean(arr = []) { | ||
| const end = this.readPackedEnd(); | ||
| while (this.pos < end) arr.push(this.readBoolean()); | ||
| return arr; | ||
| }, | ||
| readPackedFloat: function(arr) { | ||
| if (this.type !== Pbf.Bytes) return arr.push(this.readFloat()); | ||
| var end = readPackedEnd(this); | ||
| arr = arr || []; | ||
| } | ||
| /** @param {number[]} [arr] */ | ||
| readPackedFloat(arr = []) { | ||
| const end = this.readPackedEnd(); | ||
| while (this.pos < end) arr.push(this.readFloat()); | ||
| return arr; | ||
| }, | ||
| readPackedDouble: function(arr) { | ||
| if (this.type !== Pbf.Bytes) return arr.push(this.readDouble()); | ||
| var end = readPackedEnd(this); | ||
| arr = arr || []; | ||
| } | ||
| /** @param {number[]} [arr] */ | ||
| readPackedDouble(arr = []) { | ||
| const end = this.readPackedEnd(); | ||
| while (this.pos < end) arr.push(this.readDouble()); | ||
| return arr; | ||
| }, | ||
| readPackedFixed32: function(arr) { | ||
| if (this.type !== Pbf.Bytes) return arr.push(this.readFixed32()); | ||
| var end = readPackedEnd(this); | ||
| arr = arr || []; | ||
| } | ||
| /** @param {number[]} [arr] */ | ||
| readPackedFixed32(arr = []) { | ||
| const end = this.readPackedEnd(); | ||
| while (this.pos < end) arr.push(this.readFixed32()); | ||
| return arr; | ||
| }, | ||
| readPackedSFixed32: function(arr) { | ||
| if (this.type !== Pbf.Bytes) return arr.push(this.readSFixed32()); | ||
| var end = readPackedEnd(this); | ||
| arr = arr || []; | ||
| } | ||
| /** @param {number[]} [arr] */ | ||
| readPackedSFixed32(arr = []) { | ||
| const end = this.readPackedEnd(); | ||
| while (this.pos < end) arr.push(this.readSFixed32()); | ||
| return arr; | ||
| }, | ||
| readPackedFixed64: function(arr) { | ||
| if (this.type !== Pbf.Bytes) return arr.push(this.readFixed64()); | ||
| var end = readPackedEnd(this); | ||
| arr = arr || []; | ||
| } | ||
| /** @param {number[]} [arr] */ | ||
| readPackedFixed64(arr = []) { | ||
| const end = this.readPackedEnd(); | ||
| while (this.pos < end) arr.push(this.readFixed64()); | ||
| return arr; | ||
| }, | ||
| readPackedSFixed64: function(arr) { | ||
| if (this.type !== Pbf.Bytes) return arr.push(this.readSFixed64()); | ||
| var end = readPackedEnd(this); | ||
| arr = arr || []; | ||
| } | ||
| /** @param {number[]} [arr] */ | ||
| readPackedSFixed64(arr = []) { | ||
| const end = this.readPackedEnd(); | ||
| while (this.pos < end) arr.push(this.readSFixed64()); | ||
| return arr; | ||
| }, | ||
| } | ||
| readPackedEnd() { | ||
| return this.type === PBF_BYTES ? this.readVarint() + this.pos : this.pos + 1; | ||
| } | ||
| skip: function(val) { | ||
| var type = val & 0x7; | ||
| if (type === Pbf.Varint) while (this.buf[this.pos++] > 0x7f) {} | ||
| else if (type === Pbf.Bytes) this.pos = this.readVarint() + this.pos; | ||
| else if (type === Pbf.Fixed32) this.pos += 4; | ||
| else if (type === Pbf.Fixed64) this.pos += 8; | ||
| else throw new Error('Unimplemented type: ' + type); | ||
| }, | ||
| /** @param {number} val */ | ||
| skip(val) { | ||
| const type = val & 0x7; | ||
| if (type === PBF_VARINT) while (this.buf[this.pos++] > 0x7f) {} | ||
| else if (type === PBF_BYTES) this.pos = this.readVarint() + this.pos; | ||
| else if (type === PBF_FIXED32) this.pos += 4; | ||
| else if (type === PBF_FIXED64) this.pos += 8; | ||
| else throw new Error(`Unimplemented type: ${type}`); | ||
| } | ||
| // === WRITING ================================================================= | ||
| writeTag: function(tag, type) { | ||
| /** | ||
| * @param {number} tag | ||
| * @param {number} type | ||
| */ | ||
| writeTag(tag, type) { | ||
| this.writeVarint((tag << 3) | type); | ||
| }, | ||
| } | ||
| realloc: function(min) { | ||
| var length = this.length || 16; | ||
| /** @param {number} min */ | ||
| realloc(min) { | ||
| let length = this.length || 16; | ||
@@ -230,42 +243,48 @@ while (length < this.pos + min) length *= 2; | ||
| if (length !== this.length) { | ||
| var buf = new Uint8Array(length); | ||
| const buf = new Uint8Array(length); | ||
| buf.set(this.buf); | ||
| this.buf = buf; | ||
| this.dataView = new DataView(buf.buffer); | ||
| this.length = length; | ||
| } | ||
| }, | ||
| } | ||
| finish: function() { | ||
| finish() { | ||
| this.length = this.pos; | ||
| this.pos = 0; | ||
| return this.buf.subarray(0, this.length); | ||
| }, | ||
| } | ||
| writeFixed32: function(val) { | ||
| /** @param {number} val */ | ||
| writeFixed32(val) { | ||
| this.realloc(4); | ||
| writeInt32(this.buf, val, this.pos); | ||
| this.dataView.setInt32(this.pos, val, true); | ||
| this.pos += 4; | ||
| }, | ||
| } | ||
| writeSFixed32: function(val) { | ||
| /** @param {number} val */ | ||
| writeSFixed32(val) { | ||
| this.realloc(4); | ||
| writeInt32(this.buf, val, this.pos); | ||
| this.dataView.setInt32(this.pos, val, true); | ||
| this.pos += 4; | ||
| }, | ||
| } | ||
| writeFixed64: function(val) { | ||
| /** @param {number} val */ | ||
| writeFixed64(val) { | ||
| this.realloc(8); | ||
| writeInt32(this.buf, val & -1, this.pos); | ||
| writeInt32(this.buf, Math.floor(val * SHIFT_RIGHT_32), this.pos + 4); | ||
| this.dataView.setInt32(this.pos, val & -1, true); | ||
| this.dataView.setInt32(this.pos + 4, Math.floor(val * SHIFT_RIGHT_32), true); | ||
| this.pos += 8; | ||
| }, | ||
| } | ||
| writeSFixed64: function(val) { | ||
| /** @param {number} val */ | ||
| writeSFixed64(val) { | ||
| this.realloc(8); | ||
| writeInt32(this.buf, val & -1, this.pos); | ||
| writeInt32(this.buf, Math.floor(val * SHIFT_RIGHT_32), this.pos + 4); | ||
| this.dataView.setInt32(this.pos, val & -1, true); | ||
| this.dataView.setInt32(this.pos + 4, Math.floor(val * SHIFT_RIGHT_32), true); | ||
| this.pos += 8; | ||
| }, | ||
| } | ||
| writeVarint: function(val) { | ||
| /** @param {number} val */ | ||
| writeVarint(val) { | ||
| val = +val || 0; | ||
@@ -284,13 +303,16 @@ | ||
| this.buf[this.pos++] = (val >>> 7) & 0x7f; | ||
| }, | ||
| } | ||
| writeSVarint: function(val) { | ||
| /** @param {number} val */ | ||
| writeSVarint(val) { | ||
| this.writeVarint(val < 0 ? -val * 2 - 1 : val * 2); | ||
| }, | ||
| } | ||
| writeBoolean: function(val) { | ||
| this.writeVarint(Boolean(val)); | ||
| }, | ||
| /** @param {boolean} val */ | ||
| writeBoolean(val) { | ||
| this.writeVarint(+val); | ||
| } | ||
| writeString: function(str) { | ||
| /** @param {string} str */ | ||
| writeString(str) { | ||
| str = String(str); | ||
@@ -301,6 +323,6 @@ this.realloc(str.length * 4); | ||
| var startPos = this.pos; | ||
| const startPos = this.pos; | ||
| // write the string directly to the buffer and see how much was written | ||
| this.pos = writeUtf8(this.buf, str, this.pos); | ||
| var len = this.pos - startPos; | ||
| const len = this.pos - startPos; | ||
@@ -313,30 +335,38 @@ if (len >= 0x80) makeRoomForExtraLength(startPos, len, this); | ||
| this.pos += len; | ||
| }, | ||
| } | ||
| writeFloat: function(val) { | ||
| /** @param {number} val */ | ||
| writeFloat(val) { | ||
| this.realloc(4); | ||
| ieee754.write(this.buf, val, this.pos, true, 23, 4); | ||
| this.dataView.setFloat32(this.pos, val, true); | ||
| this.pos += 4; | ||
| }, | ||
| } | ||
| writeDouble: function(val) { | ||
| /** @param {number} val */ | ||
| writeDouble(val) { | ||
| this.realloc(8); | ||
| ieee754.write(this.buf, val, this.pos, true, 52, 8); | ||
| this.dataView.setFloat64(this.pos, val, true); | ||
| this.pos += 8; | ||
| }, | ||
| } | ||
| writeBytes: function(buffer) { | ||
| var len = buffer.length; | ||
| /** @param {Uint8Array} buffer */ | ||
| writeBytes(buffer) { | ||
| const len = buffer.length; | ||
| this.writeVarint(len); | ||
| this.realloc(len); | ||
| for (var i = 0; i < len; i++) this.buf[this.pos++] = buffer[i]; | ||
| }, | ||
| for (let i = 0; i < len; i++) this.buf[this.pos++] = buffer[i]; | ||
| } | ||
| writeRawMessage: function(fn, obj) { | ||
| /** | ||
| * @template T | ||
| * @param {(obj: T, pbf: Pbf) => void} fn | ||
| * @param {T} obj | ||
| */ | ||
| writeRawMessage(fn, obj) { | ||
| this.pos++; // reserve 1 byte for short message length | ||
| // write the message directly to the buffer and see how much was written | ||
| var startPos = this.pos; | ||
| const startPos = this.pos; | ||
| fn(obj, this); | ||
| var len = this.pos - startPos; | ||
| const len = this.pos - startPos; | ||
@@ -349,67 +379,175 @@ if (len >= 0x80) makeRoomForExtraLength(startPos, len, this); | ||
| this.pos += len; | ||
| }, | ||
| } | ||
| writeMessage: function(tag, fn, obj) { | ||
| this.writeTag(tag, Pbf.Bytes); | ||
| /** | ||
| * @template T | ||
| * @param {number} tag | ||
| * @param {(obj: T, pbf: Pbf) => void} fn | ||
| * @param {T} obj | ||
| */ | ||
| writeMessage(tag, fn, obj) { | ||
| this.writeTag(tag, PBF_BYTES); | ||
| this.writeRawMessage(fn, obj); | ||
| }, | ||
| } | ||
| writePackedVarint: function(tag, arr) { if (arr.length) this.writeMessage(tag, writePackedVarint, arr); }, | ||
| writePackedSVarint: function(tag, arr) { if (arr.length) this.writeMessage(tag, writePackedSVarint, arr); }, | ||
| writePackedBoolean: function(tag, arr) { if (arr.length) this.writeMessage(tag, writePackedBoolean, arr); }, | ||
| writePackedFloat: function(tag, arr) { if (arr.length) this.writeMessage(tag, writePackedFloat, arr); }, | ||
| writePackedDouble: function(tag, arr) { if (arr.length) this.writeMessage(tag, writePackedDouble, arr); }, | ||
| writePackedFixed32: function(tag, arr) { if (arr.length) this.writeMessage(tag, writePackedFixed32, arr); }, | ||
| writePackedSFixed32: function(tag, arr) { if (arr.length) this.writeMessage(tag, writePackedSFixed32, arr); }, | ||
| writePackedFixed64: function(tag, arr) { if (arr.length) this.writeMessage(tag, writePackedFixed64, arr); }, | ||
| writePackedSFixed64: function(tag, arr) { if (arr.length) this.writeMessage(tag, writePackedSFixed64, arr); }, | ||
| /** | ||
| * @param {number} tag | ||
| * @param {number[]} arr | ||
| */ | ||
| writePackedVarint(tag, arr) { | ||
| if (arr.length) this.writeMessage(tag, writePackedVarint, arr); | ||
| } | ||
| /** | ||
| * @param {number} tag | ||
| * @param {number[]} arr | ||
| */ | ||
| writePackedSVarint(tag, arr) { | ||
| if (arr.length) this.writeMessage(tag, writePackedSVarint, arr); | ||
| } | ||
| /** | ||
| * @param {number} tag | ||
| * @param {boolean[]} arr | ||
| */ | ||
| writePackedBoolean(tag, arr) { | ||
| if (arr.length) this.writeMessage(tag, writePackedBoolean, arr); | ||
| } | ||
| /** | ||
| * @param {number} tag | ||
| * @param {number[]} arr | ||
| */ | ||
| writePackedFloat(tag, arr) { | ||
| if (arr.length) this.writeMessage(tag, writePackedFloat, arr); | ||
| } | ||
| /** | ||
| * @param {number} tag | ||
| * @param {number[]} arr | ||
| */ | ||
| writePackedDouble(tag, arr) { | ||
| if (arr.length) this.writeMessage(tag, writePackedDouble, arr); | ||
| } | ||
| /** | ||
| * @param {number} tag | ||
| * @param {number[]} arr | ||
| */ | ||
| writePackedFixed32(tag, arr) { | ||
| if (arr.length) this.writeMessage(tag, writePackedFixed32, arr); | ||
| } | ||
| /** | ||
| * @param {number} tag | ||
| * @param {number[]} arr | ||
| */ | ||
| writePackedSFixed32(tag, arr) { | ||
| if (arr.length) this.writeMessage(tag, writePackedSFixed32, arr); | ||
| } | ||
| /** | ||
| * @param {number} tag | ||
| * @param {number[]} arr | ||
| */ | ||
| writePackedFixed64(tag, arr) { | ||
| if (arr.length) this.writeMessage(tag, writePackedFixed64, arr); | ||
| } | ||
| /** | ||
| * @param {number} tag | ||
| * @param {number[]} arr | ||
| */ | ||
| writePackedSFixed64(tag, arr) { | ||
| if (arr.length) this.writeMessage(tag, writePackedSFixed64, arr); | ||
| } | ||
| writeBytesField: function(tag, buffer) { | ||
| this.writeTag(tag, Pbf.Bytes); | ||
| /** | ||
| * @param {number} tag | ||
| * @param {Uint8Array} buffer | ||
| */ | ||
| writeBytesField(tag, buffer) { | ||
| this.writeTag(tag, PBF_BYTES); | ||
| this.writeBytes(buffer); | ||
| }, | ||
| writeFixed32Field: function(tag, val) { | ||
| this.writeTag(tag, Pbf.Fixed32); | ||
| } | ||
| /** | ||
| * @param {number} tag | ||
| * @param {number} val | ||
| */ | ||
| writeFixed32Field(tag, val) { | ||
| this.writeTag(tag, PBF_FIXED32); | ||
| this.writeFixed32(val); | ||
| }, | ||
| writeSFixed32Field: function(tag, val) { | ||
| this.writeTag(tag, Pbf.Fixed32); | ||
| } | ||
| /** | ||
| * @param {number} tag | ||
| * @param {number} val | ||
| */ | ||
| writeSFixed32Field(tag, val) { | ||
| this.writeTag(tag, PBF_FIXED32); | ||
| this.writeSFixed32(val); | ||
| }, | ||
| writeFixed64Field: function(tag, val) { | ||
| this.writeTag(tag, Pbf.Fixed64); | ||
| } | ||
| /** | ||
| * @param {number} tag | ||
| * @param {number} val | ||
| */ | ||
| writeFixed64Field(tag, val) { | ||
| this.writeTag(tag, PBF_FIXED64); | ||
| this.writeFixed64(val); | ||
| }, | ||
| writeSFixed64Field: function(tag, val) { | ||
| this.writeTag(tag, Pbf.Fixed64); | ||
| } | ||
| /** | ||
| * @param {number} tag | ||
| * @param {number} val | ||
| */ | ||
| writeSFixed64Field(tag, val) { | ||
| this.writeTag(tag, PBF_FIXED64); | ||
| this.writeSFixed64(val); | ||
| }, | ||
| writeVarintField: function(tag, val) { | ||
| this.writeTag(tag, Pbf.Varint); | ||
| } | ||
| /** | ||
| * @param {number} tag | ||
| * @param {number} val | ||
| */ | ||
| writeVarintField(tag, val) { | ||
| this.writeTag(tag, PBF_VARINT); | ||
| this.writeVarint(val); | ||
| }, | ||
| writeSVarintField: function(tag, val) { | ||
| this.writeTag(tag, Pbf.Varint); | ||
| } | ||
| /** | ||
| * @param {number} tag | ||
| * @param {number} val | ||
| */ | ||
| writeSVarintField(tag, val) { | ||
| this.writeTag(tag, PBF_VARINT); | ||
| this.writeSVarint(val); | ||
| }, | ||
| writeStringField: function(tag, str) { | ||
| this.writeTag(tag, Pbf.Bytes); | ||
| } | ||
| /** | ||
| * @param {number} tag | ||
| * @param {string} str | ||
| */ | ||
| writeStringField(tag, str) { | ||
| this.writeTag(tag, PBF_BYTES); | ||
| this.writeString(str); | ||
| }, | ||
| writeFloatField: function(tag, val) { | ||
| this.writeTag(tag, Pbf.Fixed32); | ||
| } | ||
| /** | ||
| * @param {number} tag | ||
| * @param {number} val | ||
| */ | ||
| writeFloatField(tag, val) { | ||
| this.writeTag(tag, PBF_FIXED32); | ||
| this.writeFloat(val); | ||
| }, | ||
| writeDoubleField: function(tag, val) { | ||
| this.writeTag(tag, Pbf.Fixed64); | ||
| } | ||
| /** | ||
| * @param {number} tag | ||
| * @param {number} val | ||
| */ | ||
| writeDoubleField(tag, val) { | ||
| this.writeTag(tag, PBF_FIXED64); | ||
| this.writeDouble(val); | ||
| }, | ||
| writeBooleanField: function(tag, val) { | ||
| this.writeVarintField(tag, Boolean(val)); | ||
| } | ||
| }; | ||
| /** | ||
| * @param {number} tag | ||
| * @param {boolean} val | ||
| */ | ||
| writeBooleanField(tag, val) { | ||
| this.writeVarintField(tag, +val); | ||
| } | ||
| } | ||
| /** | ||
| * @param {number} l | ||
| * @param {boolean | undefined} s | ||
| * @param {Pbf} p | ||
| */ | ||
| function readVarintRemainder(l, s, p) { | ||
| var buf = p.buf, | ||
| h, b; | ||
| const buf = p.buf; | ||
| let h, b; | ||
@@ -426,17 +564,17 @@ b = buf[p.pos++]; h = (b & 0x70) >> 4; if (b < 0x80) return toNum(l, h, s); | ||
| function readPackedEnd(pbf) { | ||
| return pbf.type === Pbf.Bytes ? | ||
| pbf.readVarint() + pbf.pos : pbf.pos + 1; | ||
| } | ||
| /** | ||
| * @param {number} low | ||
| * @param {number} high | ||
| * @param {boolean} [isSigned] | ||
| */ | ||
| function toNum(low, high, isSigned) { | ||
| if (isSigned) { | ||
| return high * 0x100000000 + (low >>> 0); | ||
| } | ||
| return ((high >>> 0) * 0x100000000) + (low >>> 0); | ||
| return isSigned ? high * 0x100000000 + (low >>> 0) : ((high >>> 0) * 0x100000000) + (low >>> 0); | ||
| } | ||
| /** | ||
| * @param {number} val | ||
| * @param {Pbf} pbf | ||
| */ | ||
| function writeBigVarint(val, pbf) { | ||
| var low, high; | ||
| let low, high; | ||
@@ -468,2 +606,7 @@ if (val >= 0) { | ||
| /** | ||
| * @param {number} high | ||
| * @param {number} low | ||
| * @param {Pbf} pbf | ||
| */ | ||
| function writeBigVarintLow(low, high, pbf) { | ||
@@ -477,4 +620,8 @@ pbf.buf[pbf.pos++] = low & 0x7f | 0x80; low >>>= 7; | ||
| /** | ||
| * @param {number} high | ||
| * @param {Pbf} pbf | ||
| */ | ||
| function writeBigVarintHigh(high, pbf) { | ||
| var lsb = (high & 0x07) << 4; | ||
| const lsb = (high & 0x07) << 4; | ||
@@ -489,4 +636,9 @@ pbf.buf[pbf.pos++] |= lsb | ((high >>>= 3) ? 0x80 : 0); if (!high) return; | ||
| /** | ||
| * @param {number} startPos | ||
| * @param {number} len | ||
| * @param {Pbf} pbf | ||
| */ | ||
| function makeRoomForExtraLength(startPos, len, pbf) { | ||
| var extraLen = | ||
| const extraLen = | ||
| len <= 0x3fff ? 1 : | ||
@@ -498,46 +650,84 @@ len <= 0x1fffff ? 2 : | ||
| pbf.realloc(extraLen); | ||
| for (var i = pbf.pos - 1; i >= startPos; i--) pbf.buf[i + extraLen] = pbf.buf[i]; | ||
| for (let i = pbf.pos - 1; i >= startPos; i--) pbf.buf[i + extraLen] = pbf.buf[i]; | ||
| } | ||
| function writePackedVarint(arr, pbf) { for (var i = 0; i < arr.length; i++) pbf.writeVarint(arr[i]); } | ||
| function writePackedSVarint(arr, pbf) { for (var i = 0; i < arr.length; i++) pbf.writeSVarint(arr[i]); } | ||
| function writePackedFloat(arr, pbf) { for (var i = 0; i < arr.length; i++) pbf.writeFloat(arr[i]); } | ||
| function writePackedDouble(arr, pbf) { for (var i = 0; i < arr.length; i++) pbf.writeDouble(arr[i]); } | ||
| function writePackedBoolean(arr, pbf) { for (var i = 0; i < arr.length; i++) pbf.writeBoolean(arr[i]); } | ||
| function writePackedFixed32(arr, pbf) { for (var i = 0; i < arr.length; i++) pbf.writeFixed32(arr[i]); } | ||
| function writePackedSFixed32(arr, pbf) { for (var i = 0; i < arr.length; i++) pbf.writeSFixed32(arr[i]); } | ||
| function writePackedFixed64(arr, pbf) { for (var i = 0; i < arr.length; i++) pbf.writeFixed64(arr[i]); } | ||
| function writePackedSFixed64(arr, pbf) { for (var i = 0; i < arr.length; i++) pbf.writeSFixed64(arr[i]); } | ||
| // Buffer code below from https://github.com/feross/buffer, MIT-licensed | ||
| function readUInt32(buf, pos) { | ||
| return ((buf[pos]) | | ||
| (buf[pos + 1] << 8) | | ||
| (buf[pos + 2] << 16)) + | ||
| (buf[pos + 3] * 0x1000000); | ||
| /** | ||
| * @param {number[]} arr | ||
| * @param {Pbf} pbf | ||
| */ | ||
| function writePackedVarint(arr, pbf) { | ||
| for (let i = 0; i < arr.length; i++) pbf.writeVarint(arr[i]); | ||
| } | ||
| function writeInt32(buf, val, pos) { | ||
| buf[pos] = val; | ||
| buf[pos + 1] = (val >>> 8); | ||
| buf[pos + 2] = (val >>> 16); | ||
| buf[pos + 3] = (val >>> 24); | ||
| /** | ||
| * @param {number[]} arr | ||
| * @param {Pbf} pbf | ||
| */ | ||
| function writePackedSVarint(arr, pbf) { | ||
| for (let i = 0; i < arr.length; i++) pbf.writeSVarint(arr[i]); | ||
| } | ||
| function readInt32(buf, pos) { | ||
| return ((buf[pos]) | | ||
| (buf[pos + 1] << 8) | | ||
| (buf[pos + 2] << 16)) + | ||
| (buf[pos + 3] << 24); | ||
| /** | ||
| * @param {number[]} arr | ||
| * @param {Pbf} pbf | ||
| */ | ||
| function writePackedFloat(arr, pbf) { | ||
| for (let i = 0; i < arr.length; i++) pbf.writeFloat(arr[i]); | ||
| } | ||
| /** | ||
| * @param {number[]} arr | ||
| * @param {Pbf} pbf | ||
| */ | ||
| function writePackedDouble(arr, pbf) { | ||
| for (let i = 0; i < arr.length; i++) pbf.writeDouble(arr[i]); | ||
| } | ||
| /** | ||
| * @param {boolean[]} arr | ||
| * @param {Pbf} pbf | ||
| */ | ||
| function writePackedBoolean(arr, pbf) { | ||
| for (let i = 0; i < arr.length; i++) pbf.writeBoolean(arr[i]); | ||
| } | ||
| /** | ||
| * @param {number[]} arr | ||
| * @param {Pbf} pbf | ||
| */ | ||
| function writePackedFixed32(arr, pbf) { | ||
| for (let i = 0; i < arr.length; i++) pbf.writeFixed32(arr[i]); | ||
| } | ||
| /** | ||
| * @param {number[]} arr | ||
| * @param {Pbf} pbf | ||
| */ | ||
| function writePackedSFixed32(arr, pbf) { | ||
| for (let i = 0; i < arr.length; i++) pbf.writeSFixed32(arr[i]); | ||
| } | ||
| /** | ||
| * @param {number[]} arr | ||
| * @param {Pbf} pbf | ||
| */ | ||
| function writePackedFixed64(arr, pbf) { | ||
| for (let i = 0; i < arr.length; i++) pbf.writeFixed64(arr[i]); | ||
| } | ||
| /** | ||
| * @param {number[]} arr | ||
| * @param {Pbf} pbf | ||
| */ | ||
| function writePackedSFixed64(arr, pbf) { | ||
| for (let i = 0; i < arr.length; i++) pbf.writeSFixed64(arr[i]); | ||
| } | ||
| // Buffer code below from https://github.com/feross/buffer, MIT-licensed | ||
| /** | ||
| * @param {Uint8Array} buf | ||
| * @param {number} pos | ||
| * @param {number} end | ||
| */ | ||
| function readUtf8(buf, pos, end) { | ||
| var str = ''; | ||
| var i = pos; | ||
| let str = ''; | ||
| let i = pos; | ||
| while (i < end) { | ||
| var b0 = buf[i]; | ||
| var c = null; // codepoint | ||
| var bytesPerSequence = | ||
| const b0 = buf[i]; | ||
| let c = null; // codepoint | ||
| let bytesPerSequence = | ||
| b0 > 0xEF ? 4 : | ||
@@ -549,3 +739,3 @@ b0 > 0xDF ? 3 : | ||
| var b1, b2, b3; | ||
| let b1, b2, b3; | ||
@@ -602,8 +792,9 @@ if (bytesPerSequence === 1) { | ||
| function readUtf8TextDecoder(buf, pos, end) { | ||
| return utf8TextDecoder.decode(buf.subarray(pos, end)); | ||
| } | ||
| /** | ||
| * @param {Uint8Array} buf | ||
| * @param {string} str | ||
| * @param {number} pos | ||
| */ | ||
| function writeUtf8(buf, str, pos) { | ||
| for (var i = 0, c, lead; i < str.length; i++) { | ||
| for (let i = 0, c, lead; i < str.length; i++) { | ||
| c = str.charCodeAt(i); // code point | ||
@@ -660,92 +851,4 @@ | ||
| },{"ieee754":2}],2:[function(require,module,exports){ | ||
| /*! ieee754. BSD-3-Clause License. Feross Aboukhadijeh <https://feross.org/opensource> */ | ||
| exports.read = function (buffer, offset, isLE, mLen, nBytes) { | ||
| var e, m | ||
| var eLen = (nBytes * 8) - mLen - 1 | ||
| var eMax = (1 << eLen) - 1 | ||
| var eBias = eMax >> 1 | ||
| var nBits = -7 | ||
| var i = isLE ? (nBytes - 1) : 0 | ||
| var d = isLE ? -1 : 1 | ||
| var s = buffer[offset + i] | ||
| return Pbf; | ||
| i += d | ||
| e = s & ((1 << (-nBits)) - 1) | ||
| s >>= (-nBits) | ||
| nBits += eLen | ||
| for (; nBits > 0; e = (e * 256) + buffer[offset + i], i += d, nBits -= 8) {} | ||
| m = e & ((1 << (-nBits)) - 1) | ||
| e >>= (-nBits) | ||
| nBits += mLen | ||
| for (; nBits > 0; m = (m * 256) + buffer[offset + i], i += d, nBits -= 8) {} | ||
| if (e === 0) { | ||
| e = 1 - eBias | ||
| } else if (e === eMax) { | ||
| return m ? NaN : ((s ? -1 : 1) * Infinity) | ||
| } else { | ||
| m = m + Math.pow(2, mLen) | ||
| e = e - eBias | ||
| } | ||
| return (s ? -1 : 1) * m * Math.pow(2, e - mLen) | ||
| } | ||
| exports.write = function (buffer, value, offset, isLE, mLen, nBytes) { | ||
| var e, m, c | ||
| var eLen = (nBytes * 8) - mLen - 1 | ||
| var eMax = (1 << eLen) - 1 | ||
| var eBias = eMax >> 1 | ||
| var rt = (mLen === 23 ? Math.pow(2, -24) - Math.pow(2, -77) : 0) | ||
| var i = isLE ? 0 : (nBytes - 1) | ||
| var d = isLE ? 1 : -1 | ||
| var s = value < 0 || (value === 0 && 1 / value < 0) ? 1 : 0 | ||
| value = Math.abs(value) | ||
| if (isNaN(value) || value === Infinity) { | ||
| m = isNaN(value) ? 1 : 0 | ||
| e = eMax | ||
| } else { | ||
| e = Math.floor(Math.log(value) / Math.LN2) | ||
| if (value * (c = Math.pow(2, -e)) < 1) { | ||
| e-- | ||
| c *= 2 | ||
| } | ||
| if (e + eBias >= 1) { | ||
| value += rt / c | ||
| } else { | ||
| value += rt * Math.pow(2, 1 - eBias) | ||
| } | ||
| if (value * c >= 2) { | ||
| e++ | ||
| c /= 2 | ||
| } | ||
| if (e + eBias >= eMax) { | ||
| m = 0 | ||
| e = eMax | ||
| } else if (e + eBias >= 1) { | ||
| m = ((value * c) - 1) * Math.pow(2, mLen) | ||
| e = e + eBias | ||
| } else { | ||
| m = value * Math.pow(2, eBias - 1) * Math.pow(2, mLen) | ||
| e = 0 | ||
| } | ||
| } | ||
| for (; mLen >= 8; buffer[offset + i] = m & 0xff, i += d, m /= 256, mLen -= 8) {} | ||
| e = (e << mLen) | m | ||
| eLen += mLen | ||
| for (; eLen > 0; buffer[offset + i] = e & 0xff, i += d, e /= 256, eLen -= 8) {} | ||
| buffer[offset + i - d] |= s * 128 | ||
| } | ||
| },{}]},{},[1])(1) | ||
| }); | ||
| //# sourceMappingURL=data:application/json;charset=utf-8;base64,eyJ2ZXJzaW9uIjozLCJzb3VyY2VzIjpbIm5vZGVfbW9kdWxlcy9icm93c2VyLXBhY2svX3ByZWx1ZGUuanMiLCJpbmRleC5qcyIsIm5vZGVfbW9kdWxlcy9pZWVlNzU0L2luZGV4LmpzIl0sIm5hbWVzIjpbXSwibWFwcGluZ3MiOiJBQUFBO0FDQUE7QUFDQTtBQUNBO0FBQ0E7QUFDQTtBQUNBO0FBQ0E7QUFDQTtBQUNBO0FBQ0E7QUFDQTtBQUNBO0FBQ0E7QUFDQTtBQUNBO0FBQ0E7QUFDQTtBQUNBO0FBQ0E7QUFDQTtBQUNBO0FBQ0E7QUFDQTtBQUNBO0FBQ0E7QUFDQTtBQUNBO0FBQ0E7QUFDQTtBQUNBO0FBQ0E7QUFDQTtBQUNBO0FBQ0E7QUFDQTtBQUNBO0FBQ0E7QUFDQTtBQUNBO0FBQ0E7QUFDQTtBQUNBO0FBQ0E7QUFDQTtBQUNBO0FBQ0E7QUFDQTtBQUNBO0FBQ0E7QUFDQTtBQUNBO0FBQ0E7QUFDQTtBQUNBO0FBQ0E7QUFDQTtBQUNBO0FBQ0E7QUFDQTtBQUNBO0FBQ0E7QUFDQTtBQUNBO0FBQ0E7QUFDQTtBQUNBO0FBQ0E7QUFDQTtBQUNBO0FBQ0E7QUFDQTtBQUNBO0FBQ0E7QUFDQTtBQUNBO0FBQ0E7QUFDQTtBQUNBO0FBQ0E7QUFDQTtBQUNBO0FBQ0E7QUFDQTtBQUNBO0FBQ0E7QUFDQTtBQUNBO0FBQ0E7QUFDQTtBQUNBO0FBQ0E7QUFDQTtBQUNBO0FBQ0E7QUFDQTtBQUNBO0FBQ0E7QUFDQTtBQUNBO0FBQ0E7QUFDQTtBQUNBO0FBQ0E7QUFDQTtBQUNBO0FBQ0E7QUFDQTtBQUNBO0FBQ0E7QUFDQTtBQUNBO0FBQ0E7QUFDQTtBQUNBO0FBQ0E7QUFDQTtBQUNBO0FBQ0E7QUFDQTtBQUNBO0FBQ0E7QUFDQTtBQUNBO0FBQ0E7QUFDQTtBQUNBO0FBQ0E7QUFDQTtBQUNBO0FBQ0E7QUFDQTtBQUNBO0FBQ0E7QUFDQTtBQUNBO0FBQ0E7QUFDQTtBQUNBO0FBQ0E7QUFDQTtBQUNBO0FBQ0E7QUFDQTtBQUNBO0FBQ0E7QUFDQTtBQUNBO0FBQ0E7QUFDQTtBQUNBO0FBQ0E7QUFDQTtBQUNBO0FBQ0E7QUFDQTtBQUNBO0FBQ0E7QUFDQTtBQUNBO0FBQ0E7QUFDQTtBQUNBO0FBQ0E7QUFDQTtBQUNBO0FBQ0E7QUFDQTtBQUNBO0FBQ0E7QUFDQTtBQUNBO0FBQ0E7QUFDQTtBQUNBO0FBQ0E7QUFDQTtBQUNBO0FBQ0E7QUFDQTtBQUNBO0FBQ0E7QUFDQTtBQUNBO0FBQ0E7QUFDQTtBQUNBO0FBQ0E7QUFDQTtBQUNBO0FBQ0E7QUFDQTtBQUNBO0FBQ0E7QUFDQTtBQUNBO0FBQ0E7QUFDQTtBQUNBO0FBQ0E7QUFDQTtBQUNBO0FBQ0E7QUFDQTtBQUNBO0FBQ0E7QUFDQTtBQUNBO0FBQ0E7QUFDQTtBQUNBO0FBQ0E7QUFDQTtBQUNBO0FBQ0E7QUFDQTtBQUNBO0FBQ0E7QUFDQTtBQUNBO0FBQ0E7QUFDQTtBQUNBO0FBQ0E7QUFDQTtBQUNBO0FBQ0E7QUFDQTtBQUNBO0FBQ0E7QUFDQTtBQUNBO0FBQ0E7QUFDQTtBQUNBO0FBQ0E7QUFDQTtBQUNBO0FBQ0E7QUFDQTtBQUNBO0FBQ0E7QUFDQTtBQUNBO0FBQ0E7QUFDQTtBQUNBO0FBQ0E7QUFDQTtBQUNBO0FBQ0E7QUFDQTtBQUNBO0FBQ0E7QUFDQTtBQUNBO0FBQ0E7QUFDQTtBQUNBO0FBQ0E7QUFDQTtBQUNBO0FBQ0E7QUFDQTtBQUNBO0FBQ0E7QUFDQTtBQUNBO0FBQ0E7QUFDQTtBQUNBO0FBQ0E7QUFDQTtBQUNBO0FBQ0E7QUFDQTtBQUNBO0FBQ0E7QUFDQTtBQUNBO0FBQ0E7QUFDQTtBQUNBO0FBQ0E7QUFDQTtBQUNBO0FBQ0E7QUFDQTtBQUNBO0FBQ0E7QUFDQTtBQUNBO0FBQ0E7QUFDQTtBQUNBO0FBQ0E7QUFDQTtBQUNBO0FBQ0E7QUFDQTtBQUNBO0FBQ0E7QUFDQTtBQUNBO0FBQ0E7QUFDQTtBQUNBO0FBQ0E7QUFDQTtBQUNBO0FBQ0E7QUFDQTtBQUNBO0FBQ0E7QUFDQTtBQUNBO0FBQ0E7QUFDQTtBQUNBO0FBQ0E7QUFDQTtBQUNBO0FBQ0E7QUFDQTtBQUNBO0FBQ0E7QUFDQTtBQUNBO0FBQ0E7QUFDQTtBQUNBO0FBQ0E7QUFDQTtBQUNBO0FBQ0E7QUFDQTtBQUNBO0FBQ0E7QUFDQTtBQUNBO0FBQ0E7QUFDQTtBQUNBO0FBQ0E7QUFDQTtBQUNBO0FBQ0E7QUFDQTtBQUNBO0FBQ0E7QUFDQTtBQUNBO0FBQ0E7QUFDQTtBQUNBO0FBQ0E7QUFDQTtBQUNBO0FBQ0E7QUFDQTtBQUNBO0FBQ0E7QUFDQTtBQUNBO0FBQ0E7QUFDQTtBQUNBO0FBQ0E7QUFDQTtBQUNBO0FBQ0E7QUFDQTtBQUNBO0FBQ0E7QUFDQTtBQUNBO0FBQ0E7QUFDQTtBQUNBO0FBQ0E7QUFDQTtBQUNBO0FBQ0E7QUFDQTtBQUNBO0FBQ0E7QUFDQTtBQUNBO0FBQ0E7QUFDQTtBQUNBO0FBQ0E7QUFDQTtBQUNBO0FBQ0E7QUFDQTtBQUNBO0FBQ0E7QUFDQTtBQUNBO0FBQ0E7QUFDQTtBQUNBO0FBQ0E7QUFDQTtBQUNBO0FBQ0E7QUFDQTtBQUNBO0FBQ0E7QUFDQTtBQUNBO0FBQ0E7QUFDQTtBQUNBO0FBQ0E7QUFDQTtBQUNBO0FBQ0E7QUFDQTtBQUNBO0FBQ0E7QUFDQTtBQUNBO0FBQ0E7QUFDQTtBQUNBO0FBQ0E7QUFDQTtBQUNBO0FBQ0E7QUFDQTtBQUNBO0FBQ0E7QUFDQTtBQUNBO0FBQ0E7QUFDQTtBQUNBO0FBQ0E7QUFDQTtBQUNBO0FBQ0E7QUFDQTtBQUNBO0FBQ0E7QUFDQTtBQUNBO0FBQ0E7QUFDQTtBQUNBO0FBQ0E7QUFDQTtBQUNBO0FBQ0E7QUFDQTtBQUNBO0FBQ0E7QUFDQTtBQUNBO0FBQ0E7QUFDQTtBQUNBO0FBQ0E7QUFDQTtBQUNBO0FBQ0E7QUFDQTtBQUNBO0FBQ0E7QUFDQTtBQUNBO0FBQ0E7QUFDQTtBQUNBO0FBQ0E7QUFDQTtBQUNBO0FBQ0E7QUFDQTtBQUNBO0FBQ0E7QUFDQTtBQUNBO0FBQ0E7QUFDQTtBQUNBO0FBQ0E7QUFDQTtBQUNBO0FBQ0E7QUFDQTtBQUNBO0FBQ0E7QUFDQTtBQUNBO0FBQ0E7QUFDQTtBQUNBO0FBQ0E7QUFDQTtBQUNBO0FBQ0E7QUFDQTtBQUNBO0FBQ0E7QUFDQTtBQUNBO0FBQ0E7QUFDQTtBQUNBO0FBQ0E7QUFDQTtBQUNBO0FBQ0E7QUFDQTtBQUNBO0FBQ0E7QUFDQTtBQUNBO0FBQ0E7QUFDQTtBQUNBO0FBQ0E7QUFDQTtBQUNBO0FBQ0E7QUFDQTtBQUNBO0FBQ0E7QUFDQTtBQUNBO0FBQ0E7QUFDQTtBQUNBO0FBQ0E7QUFDQTtBQUNBO0FBQ0E7QUFDQTtBQUNBO0FBQ0E7QUFDQTtBQUNBO0FBQ0E7QUFDQTtBQUNBO0FBQ0E7QUFDQTtBQUNBO0FBQ0E7QUFDQTtBQUNBO0FBQ0E7QUFDQTtBQUNBO0FBQ0E7QUFDQTtBQUNBO0FBQ0E7QUFDQTtBQUNBO0FBQ0E7QUFDQTtBQUNBO0FBQ0E7QUFDQTtBQUNBO0FBQ0E7QUFDQTtBQUNBO0FBQ0E7QUFDQTtBQUNBO0FBQ0E7QUFDQTtBQUNBO0FBQ0E7QUFDQTtBQUNBO0FBQ0E7QUFDQTtBQUNBO0FBQ0E7QUFDQTtBQUNBO0FBQ0E7QUFDQTtBQUNBO0FBQ0E7QUFDQTtBQUNBO0FBQ0E7QUFDQTtBQUNBO0FBQ0E7QUFDQTtBQUNBO0FBQ0E7QUFDQTtBQUNBO0FBQ0E7QUFDQTtBQUNBO0FBQ0E7QUFDQTtBQUNBO0FBQ0E7QUFDQTtBQUNBO0FBQ0E7QUFDQTtBQUNBO0FBQ0E7QUFDQTtBQUNBO0FBQ0E7QUFDQTtBQUNBO0FBQ0E7QUFDQTtBQUNBO0FBQ0E7QUFDQTtBQUNBO0FBQ0E7QUFDQTtBQUNBO0FBQ0E7QUFDQTtBQUNBO0FBQ0E7QUFDQTtBQUNBO0FBQ0E7QUFDQTtBQUNBO0FBQ0E7QUFDQTtBQUNBO0FBQ0E7QUFDQTtBQUNBO0FBQ0E7O0FDbG9CQTtBQUNBO0FBQ0E7QUFDQTtBQUNBO0FBQ0E7QUFDQTtBQUNBO0FBQ0E7QUFDQTtBQUNBO0FBQ0E7QUFDQTtBQUNBO0FBQ0E7QUFDQTtBQUNBO0FBQ0E7QUFDQTtBQUNBO0FBQ0E7QUFDQTtBQUNBO0FBQ0E7QUFDQTtBQUNBO0FBQ0E7QUFDQTtBQUNBO0FBQ0E7QUFDQTtBQUNBO0FBQ0E7QUFDQTtBQUNBO0FBQ0E7QUFDQTtBQUNBO0FBQ0E7QUFDQTtBQUNBO0FBQ0E7QUFDQTtBQUNBO0FBQ0E7QUFDQTtBQUNBO0FBQ0E7QUFDQTtBQUNBO0FBQ0E7QUFDQTtBQUNBO0FBQ0E7QUFDQTtBQUNBO0FBQ0E7QUFDQTtBQUNBO0FBQ0E7QUFDQTtBQUNBO0FBQ0E7QUFDQTtBQUNBO0FBQ0E7QUFDQTtBQUNBO0FBQ0E7QUFDQTtBQUNBO0FBQ0E7QUFDQTtBQUNBO0FBQ0E7QUFDQTtBQUNBO0FBQ0E7QUFDQTtBQUNBO0FBQ0E7QUFDQTtBQUNBO0FBQ0E7QUFDQTtBQUNBIiwiZmlsZSI6ImdlbmVyYXRlZC5qcyIsInNvdXJjZVJvb3QiOiIiLCJzb3VyY2VzQ29udGVudCI6WyIoZnVuY3Rpb24oKXtmdW5jdGlvbiByKGUsbix0KXtmdW5jdGlvbiBvKGksZil7aWYoIW5baV0pe2lmKCFlW2ldKXt2YXIgYz1cImZ1bmN0aW9uXCI9PXR5cGVvZiByZXF1aXJlJiZyZXF1aXJlO2lmKCFmJiZjKXJldHVybiBjKGksITApO2lmKHUpcmV0dXJuIHUoaSwhMCk7dmFyIGE9bmV3IEVycm9yKFwiQ2Fubm90IGZpbmQgbW9kdWxlICdcIitpK1wiJ1wiKTt0aHJvdyBhLmNvZGU9XCJNT0RVTEVfTk9UX0ZPVU5EXCIsYX12YXIgcD1uW2ldPXtleHBvcnRzOnt9fTtlW2ldWzBdLmNhbGwocC5leHBvcnRzLGZ1bmN0aW9uKHIpe3ZhciBuPWVbaV1bMV1bcl07cmV0dXJuIG8obnx8cil9LHAscC5leHBvcnRzLHIsZSxuLHQpfXJldHVybiBuW2ldLmV4cG9ydHN9Zm9yKHZhciB1PVwiZnVuY3Rpb25cIj09dHlwZW9mIHJlcXVpcmUmJnJlcXVpcmUsaT0wO2k8dC5sZW5ndGg7aSsrKW8odFtpXSk7cmV0dXJuIG99cmV0dXJuIHJ9KSgpIiwiJ3VzZSBzdHJpY3QnO1xuXG5tb2R1bGUuZXhwb3J0cyA9IFBiZjtcblxudmFyIGllZWU3NTQgPSByZXF1aXJlKCdpZWVlNzU0Jyk7XG5cbmZ1bmN0aW9uIFBiZihidWYpIHtcbiAgICB0aGlzLmJ1ZiA9IEFycmF5QnVmZmVyLmlzVmlldyAmJiBBcnJheUJ1ZmZlci5pc1ZpZXcoYnVmKSA/IGJ1ZiA6IG5ldyBVaW50OEFycmF5KGJ1ZiB8fCAwKTtcbiAgICB0aGlzLnBvcyA9IDA7XG4gICAgdGhpcy50eXBlID0gMDtcbiAgICB0aGlzLmxlbmd0aCA9IHRoaXMuYnVmLmxlbmd0aDtcbn1cblxuUGJmLlZhcmludCAgPSAwOyAvLyB2YXJpbnQ6IGludDMyLCBpbnQ2NCwgdWludDMyLCB1aW50NjQsIHNpbnQzMiwgc2ludDY0LCBib29sLCBlbnVtXG5QYmYuRml4ZWQ2NCA9IDE7IC8vIDY0LWJpdDogZG91YmxlLCBmaXhlZDY0LCBzZml4ZWQ2NFxuUGJmLkJ5dGVzICAgPSAyOyAvLyBsZW5ndGgtZGVsaW1pdGVkOiBzdHJpbmcsIGJ5dGVzLCBlbWJlZGRlZCBtZXNzYWdlcywgcGFja2VkIHJlcGVhdGVkIGZpZWxkc1xuUGJmLkZpeGVkMzIgPSA1OyAvLyAzMi1iaXQ6IGZsb2F0LCBmaXhlZDMyLCBzZml4ZWQzMlxuXG52YXIgU0hJRlRfTEVGVF8zMiA9ICgxIDw8IDE2KSAqICgxIDw8IDE2KSxcbiAgICBTSElGVF9SSUdIVF8zMiA9IDEgLyBTSElGVF9MRUZUXzMyO1xuXG4vLyBUaHJlc2hvbGQgY2hvc2VuIGJhc2VkIG9uIGJvdGggYmVuY2htYXJraW5nIGFuZCBrbm93bGVkZ2UgYWJvdXQgYnJvd3NlciBzdHJpbmdcbi8vIGRhdGEgc3RydWN0dXJlcyAod2hpY2ggY3VycmVudGx5IHN3aXRjaCBzdHJ1Y3R1cmUgdHlwZXMgYXQgMTIgYnl0ZXMgb3IgbW9yZSlcbnZhciBURVhUX0RFQ09ERVJfTUlOX0xFTkdUSCA9IDEyO1xudmFyIHV0ZjhUZXh0RGVjb2RlciA9IHR5cGVvZiBUZXh0RGVjb2RlciA9PT0gJ3VuZGVmaW5lZCcgPyBudWxsIDogbmV3IFRleHREZWNvZGVyKCd1dGYtOCcpO1xuXG5QYmYucHJvdG90eXBlID0ge1xuXG4gICAgZGVzdHJveTogZnVuY3Rpb24oKSB7XG4gICAgICAgIHRoaXMuYnVmID0gbnVsbDtcbiAgICB9LFxuXG4gICAgLy8gPT09IFJFQURJTkcgPT09PT09PT09PT09PT09PT09PT09PT09PT09PT09PT09PT09PT09PT09PT09PT09PT09PT09PT09PT09PT09PT1cblxuICAgIHJlYWRGaWVsZHM6IGZ1bmN0aW9uKHJlYWRGaWVsZCwgcmVzdWx0LCBlbmQpIHtcbiAgICAgICAgZW5kID0gZW5kIHx8IHRoaXMubGVuZ3RoO1xuXG4gICAgICAgIHdoaWxlICh0aGlzLnBvcyA8IGVuZCkge1xuICAgICAgICAgICAgdmFyIHZhbCA9IHRoaXMucmVhZFZhcmludCgpLFxuICAgICAgICAgICAgICAgIHRhZyA9IHZhbCA+PiAzLFxuICAgICAgICAgICAgICAgIHN0YXJ0UG9zID0gdGhpcy5wb3M7XG5cbiAgICAgICAgICAgIHRoaXMudHlwZSA9IHZhbCAmIDB4NztcbiAgICAgICAgICAgIHJlYWRGaWVsZCh0YWcsIHJlc3VsdCwgdGhpcyk7XG5cbiAgICAgICAgICAgIGlmICh0aGlzLnBvcyA9PT0gc3RhcnRQb3MpIHRoaXMuc2tpcCh2YWwpO1xuICAgICAgICB9XG4gICAgICAgIHJldHVybiByZXN1bHQ7XG4gICAgfSxcblxuICAgIHJlYWRNZXNzYWdlOiBmdW5jdGlvbihyZWFkRmllbGQsIHJlc3VsdCkge1xuICAgICAgICByZXR1cm4gdGhpcy5yZWFkRmllbGRzKHJlYWRGaWVsZCwgcmVzdWx0LCB0aGlzLnJlYWRWYXJpbnQoKSArIHRoaXMucG9zKTtcbiAgICB9LFxuXG4gICAgcmVhZEZpeGVkMzI6IGZ1bmN0aW9uKCkge1xuICAgICAgICB2YXIgdmFsID0gcmVhZFVJbnQzMih0aGlzLmJ1ZiwgdGhpcy5wb3MpO1xuICAgICAgICB0aGlzLnBvcyArPSA0O1xuICAgICAgICByZXR1cm4gdmFsO1xuICAgIH0sXG5cbiAgICByZWFkU0ZpeGVkMzI6IGZ1bmN0aW9uKCkge1xuICAgICAgICB2YXIgdmFsID0gcmVhZEludDMyKHRoaXMuYnVmLCB0aGlzLnBvcyk7XG4gICAgICAgIHRoaXMucG9zICs9IDQ7XG4gICAgICAgIHJldHVybiB2YWw7XG4gICAgfSxcblxuICAgIC8vIDY0LWJpdCBpbnQgaGFuZGxpbmcgaXMgYmFzZWQgb24gZ2l0aHViLmNvbS9kcHcvbm9kZS1idWZmZXItbW9yZS1pbnRzIChNSVQtbGljZW5zZWQpXG5cbiAgICByZWFkRml4ZWQ2NDogZnVuY3Rpb24oKSB7XG4gICAgICAgIHZhciB2YWwgPSByZWFkVUludDMyKHRoaXMuYnVmLCB0aGlzLnBvcykgKyByZWFkVUludDMyKHRoaXMuYnVmLCB0aGlzLnBvcyArIDQpICogU0hJRlRfTEVGVF8zMjtcbiAgICAgICAgdGhpcy5wb3MgKz0gODtcbiAgICAgICAgcmV0dXJuIHZhbDtcbiAgICB9LFxuXG4gICAgcmVhZFNGaXhlZDY0OiBmdW5jdGlvbigpIHtcbiAgICAgICAgdmFyIHZhbCA9IHJlYWRVSW50MzIodGhpcy5idWYsIHRoaXMucG9zKSArIHJlYWRJbnQzMih0aGlzLmJ1ZiwgdGhpcy5wb3MgKyA0KSAqIFNISUZUX0xFRlRfMzI7XG4gICAgICAgIHRoaXMucG9zICs9IDg7XG4gICAgICAgIHJldHVybiB2YWw7XG4gICAgfSxcblxuICAgIHJlYWRGbG9hdDogZnVuY3Rpb24oKSB7XG4gICAgICAgIHZhciB2YWwgPSBpZWVlNzU0LnJlYWQodGhpcy5idWYsIHRoaXMucG9zLCB0cnVlLCAyMywgNCk7XG4gICAgICAgIHRoaXMucG9zICs9IDQ7XG4gICAgICAgIHJldHVybiB2YWw7XG4gICAgfSxcblxuICAgIHJlYWREb3VibGU6IGZ1bmN0aW9uKCkge1xuICAgICAgICB2YXIgdmFsID0gaWVlZTc1NC5yZWFkKHRoaXMuYnVmLCB0aGlzLnBvcywgdHJ1ZSwgNTIsIDgpO1xuICAgICAgICB0aGlzLnBvcyArPSA4O1xuICAgICAgICByZXR1cm4gdmFsO1xuICAgIH0sXG5cbiAgICByZWFkVmFyaW50OiBmdW5jdGlvbihpc1NpZ25lZCkge1xuICAgICAgICB2YXIgYnVmID0gdGhpcy5idWYsXG4gICAgICAgICAgICB2YWwsIGI7XG5cbiAgICAgICAgYiA9IGJ1Zlt0aGlzLnBvcysrXTsgdmFsICA9ICBiICYgMHg3ZjsgICAgICAgIGlmIChiIDwgMHg4MCkgcmV0dXJuIHZhbDtcbiAgICAgICAgYiA9IGJ1Zlt0aGlzLnBvcysrXTsgdmFsIHw9IChiICYgMHg3ZikgPDwgNzsgIGlmIChiIDwgMHg4MCkgcmV0dXJuIHZhbDtcbiAgICAgICAgYiA9IGJ1Zlt0aGlzLnBvcysrXTsgdmFsIHw9IChiICYgMHg3ZikgPDwgMTQ7IGlmIChiIDwgMHg4MCkgcmV0dXJuIHZhbDtcbiAgICAgICAgYiA9IGJ1Zlt0aGlzLnBvcysrXTsgdmFsIHw9IChiICYgMHg3ZikgPDwgMjE7IGlmIChiIDwgMHg4MCkgcmV0dXJuIHZhbDtcbiAgICAgICAgYiA9IGJ1Zlt0aGlzLnBvc107ICAgdmFsIHw9IChiICYgMHgwZikgPDwgMjg7XG5cbiAgICAgICAgcmV0dXJuIHJlYWRWYXJpbnRSZW1haW5kZXIodmFsLCBpc1NpZ25lZCwgdGhpcyk7XG4gICAgfSxcblxuICAgIHJlYWRWYXJpbnQ2NDogZnVuY3Rpb24oKSB7IC8vIGZvciBjb21wYXRpYmlsaXR5IHdpdGggdjIuMC4xXG4gICAgICAgIHJldHVybiB0aGlzLnJlYWRWYXJpbnQodHJ1ZSk7XG4gICAgfSxcblxuICAgIHJlYWRTVmFyaW50OiBmdW5jdGlvbigpIHtcbiAgICAgICAgdmFyIG51bSA9IHRoaXMucmVhZFZhcmludCgpO1xuICAgICAgICByZXR1cm4gbnVtICUgMiA9PT0gMSA/IChudW0gKyAxKSAvIC0yIDogbnVtIC8gMjsgLy8gemlnemFnIGVuY29kaW5nXG4gICAgfSxcblxuICAgIHJlYWRCb29sZWFuOiBmdW5jdGlvbigpIHtcbiAgICAgICAgcmV0dXJuIEJvb2xlYW4odGhpcy5yZWFkVmFyaW50KCkpO1xuICAgIH0sXG5cbiAgICByZWFkU3RyaW5nOiBmdW5jdGlvbigpIHtcbiAgICAgICAgdmFyIGVuZCA9IHRoaXMucmVhZFZhcmludCgpICsgdGhpcy5wb3M7XG4gICAgICAgIHZhciBwb3MgPSB0aGlzLnBvcztcbiAgICAgICAgdGhpcy5wb3MgPSBlbmQ7XG5cbiAgICAgICAgaWYgKGVuZCAtIHBvcyA+PSBURVhUX0RFQ09ERVJfTUlOX0xFTkdUSCAmJiB1dGY4VGV4dERlY29kZXIpIHtcbiAgICAgICAgICAgIC8vIGxvbmdlciBzdHJpbmdzIGFyZSBmYXN0IHdpdGggdGhlIGJ1aWx0LWluIGJyb3dzZXIgVGV4dERlY29kZXIgQVBJXG4gICAgICAgICAgICByZXR1cm4gcmVhZFV0ZjhUZXh0RGVjb2Rlcih0aGlzLmJ1ZiwgcG9zLCBlbmQpO1xuICAgICAgICB9XG4gICAgICAgIC8vIHNob3J0IHN0cmluZ3MgYXJlIGZhc3Qgd2l0aCBvdXIgY3VzdG9tIGltcGxlbWVudGF0aW9uXG4gICAgICAgIHJldHVybiByZWFkVXRmOCh0aGlzLmJ1ZiwgcG9zLCBlbmQpO1xuICAgIH0sXG5cbiAgICByZWFkQnl0ZXM6IGZ1bmN0aW9uKCkge1xuICAgICAgICB2YXIgZW5kID0gdGhpcy5yZWFkVmFyaW50KCkgKyB0aGlzLnBvcyxcbiAgICAgICAgICAgIGJ1ZmZlciA9IHRoaXMuYnVmLnN1YmFycmF5KHRoaXMucG9zLCBlbmQpO1xuICAgICAgICB0aGlzLnBvcyA9IGVuZDtcbiAgICAgICAgcmV0dXJuIGJ1ZmZlcjtcbiAgICB9LFxuXG4gICAgLy8gdmVyYm9zZSBmb3IgcGVyZm9ybWFuY2UgcmVhc29uczsgZG9lc24ndCBhZmZlY3QgZ3ppcHBlZCBzaXplXG5cbiAgICByZWFkUGFja2VkVmFyaW50OiBmdW5jdGlvbihhcnIsIGlzU2lnbmVkKSB7XG4gICAgICAgIGlmICh0aGlzLnR5cGUgIT09IFBiZi5CeXRlcykgcmV0dXJuIGFyci5wdXNoKHRoaXMucmVhZFZhcmludChpc1NpZ25lZCkpO1xuICAgICAgICB2YXIgZW5kID0gcmVhZFBhY2tlZEVuZCh0aGlzKTtcbiAgICAgICAgYXJyID0gYXJyIHx8IFtdO1xuICAgICAgICB3aGlsZSAodGhpcy5wb3MgPCBlbmQpIGFyci5wdXNoKHRoaXMucmVhZFZhcmludChpc1NpZ25lZCkpO1xuICAgICAgICByZXR1cm4gYXJyO1xuICAgIH0sXG4gICAgcmVhZFBhY2tlZFNWYXJpbnQ6IGZ1bmN0aW9uKGFycikge1xuICAgICAgICBpZiAodGhpcy50eXBlICE9PSBQYmYuQnl0ZXMpIHJldHVybiBhcnIucHVzaCh0aGlzLnJlYWRTVmFyaW50KCkpO1xuICAgICAgICB2YXIgZW5kID0gcmVhZFBhY2tlZEVuZCh0aGlzKTtcbiAgICAgICAgYXJyID0gYXJyIHx8IFtdO1xuICAgICAgICB3aGlsZSAodGhpcy5wb3MgPCBlbmQpIGFyci5wdXNoKHRoaXMucmVhZFNWYXJpbnQoKSk7XG4gICAgICAgIHJldHVybiBhcnI7XG4gICAgfSxcbiAgICByZWFkUGFja2VkQm9vbGVhbjogZnVuY3Rpb24oYXJyKSB7XG4gICAgICAgIGlmICh0aGlzLnR5cGUgIT09IFBiZi5CeXRlcykgcmV0dXJuIGFyci5wdXNoKHRoaXMucmVhZEJvb2xlYW4oKSk7XG4gICAgICAgIHZhciBlbmQgPSByZWFkUGFja2VkRW5kKHRoaXMpO1xuICAgICAgICBhcnIgPSBhcnIgfHwgW107XG4gICAgICAgIHdoaWxlICh0aGlzLnBvcyA8IGVuZCkgYXJyLnB1c2godGhpcy5yZWFkQm9vbGVhbigpKTtcbiAgICAgICAgcmV0dXJuIGFycjtcbiAgICB9LFxuICAgIHJlYWRQYWNrZWRGbG9hdDogZnVuY3Rpb24oYXJyKSB7XG4gICAgICAgIGlmICh0aGlzLnR5cGUgIT09IFBiZi5CeXRlcykgcmV0dXJuIGFyci5wdXNoKHRoaXMucmVhZEZsb2F0KCkpO1xuICAgICAgICB2YXIgZW5kID0gcmVhZFBhY2tlZEVuZCh0aGlzKTtcbiAgICAgICAgYXJyID0gYXJyIHx8IFtdO1xuICAgICAgICB3aGlsZSAodGhpcy5wb3MgPCBlbmQpIGFyci5wdXNoKHRoaXMucmVhZEZsb2F0KCkpO1xuICAgICAgICByZXR1cm4gYXJyO1xuICAgIH0sXG4gICAgcmVhZFBhY2tlZERvdWJsZTogZnVuY3Rpb24oYXJyKSB7XG4gICAgICAgIGlmICh0aGlzLnR5cGUgIT09IFBiZi5CeXRlcykgcmV0dXJuIGFyci5wdXNoKHRoaXMucmVhZERvdWJsZSgpKTtcbiAgICAgICAgdmFyIGVuZCA9IHJlYWRQYWNrZWRFbmQodGhpcyk7XG4gICAgICAgIGFyciA9IGFyciB8fCBbXTtcbiAgICAgICAgd2hpbGUgKHRoaXMucG9zIDwgZW5kKSBhcnIucHVzaCh0aGlzLnJlYWREb3VibGUoKSk7XG4gICAgICAgIHJldHVybiBhcnI7XG4gICAgfSxcbiAgICByZWFkUGFja2VkRml4ZWQzMjogZnVuY3Rpb24oYXJyKSB7XG4gICAgICAgIGlmICh0aGlzLnR5cGUgIT09IFBiZi5CeXRlcykgcmV0dXJuIGFyci5wdXNoKHRoaXMucmVhZEZpeGVkMzIoKSk7XG4gICAgICAgIHZhciBlbmQgPSByZWFkUGFja2VkRW5kKHRoaXMpO1xuICAgICAgICBhcnIgPSBhcnIgfHwgW107XG4gICAgICAgIHdoaWxlICh0aGlzLnBvcyA8IGVuZCkgYXJyLnB1c2godGhpcy5yZWFkRml4ZWQzMigpKTtcbiAgICAgICAgcmV0dXJuIGFycjtcbiAgICB9LFxuICAgIHJlYWRQYWNrZWRTRml4ZWQzMjogZnVuY3Rpb24oYXJyKSB7XG4gICAgICAgIGlmICh0aGlzLnR5cGUgIT09IFBiZi5CeXRlcykgcmV0dXJuIGFyci5wdXNoKHRoaXMucmVhZFNGaXhlZDMyKCkpO1xuICAgICAgICB2YXIgZW5kID0gcmVhZFBhY2tlZEVuZCh0aGlzKTtcbiAgICAgICAgYXJyID0gYXJyIHx8IFtdO1xuICAgICAgICB3aGlsZSAodGhpcy5wb3MgPCBlbmQpIGFyci5wdXNoKHRoaXMucmVhZFNGaXhlZDMyKCkpO1xuICAgICAgICByZXR1cm4gYXJyO1xuICAgIH0sXG4gICAgcmVhZFBhY2tlZEZpeGVkNjQ6IGZ1bmN0aW9uKGFycikge1xuICAgICAgICBpZiAodGhpcy50eXBlICE9PSBQYmYuQnl0ZXMpIHJldHVybiBhcnIucHVzaCh0aGlzLnJlYWRGaXhlZDY0KCkpO1xuICAgICAgICB2YXIgZW5kID0gcmVhZFBhY2tlZEVuZCh0aGlzKTtcbiAgICAgICAgYXJyID0gYXJyIHx8IFtdO1xuICAgICAgICB3aGlsZSAodGhpcy5wb3MgPCBlbmQpIGFyci5wdXNoKHRoaXMucmVhZEZpeGVkNjQoKSk7XG4gICAgICAgIHJldHVybiBhcnI7XG4gICAgfSxcbiAgICByZWFkUGFja2VkU0ZpeGVkNjQ6IGZ1bmN0aW9uKGFycikge1xuICAgICAgICBpZiAodGhpcy50eXBlICE9PSBQYmYuQnl0ZXMpIHJldHVybiBhcnIucHVzaCh0aGlzLnJlYWRTRml4ZWQ2NCgpKTtcbiAgICAgICAgdmFyIGVuZCA9IHJlYWRQYWNrZWRFbmQodGhpcyk7XG4gICAgICAgIGFyciA9IGFyciB8fCBbXTtcbiAgICAgICAgd2hpbGUgKHRoaXMucG9zIDwgZW5kKSBhcnIucHVzaCh0aGlzLnJlYWRTRml4ZWQ2NCgpKTtcbiAgICAgICAgcmV0dXJuIGFycjtcbiAgICB9LFxuXG4gICAgc2tpcDogZnVuY3Rpb24odmFsKSB7XG4gICAgICAgIHZhciB0eXBlID0gdmFsICYgMHg3O1xuICAgICAgICBpZiAodHlwZSA9PT0gUGJmLlZhcmludCkgd2hpbGUgKHRoaXMuYnVmW3RoaXMucG9zKytdID4gMHg3Zikge31cbiAgICAgICAgZWxzZSBpZiAodHlwZSA9PT0gUGJmLkJ5dGVzKSB0aGlzLnBvcyA9IHRoaXMucmVhZFZhcmludCgpICsgdGhpcy5wb3M7XG4gICAgICAgIGVsc2UgaWYgKHR5cGUgPT09IFBiZi5GaXhlZDMyKSB0aGlzLnBvcyArPSA0O1xuICAgICAgICBlbHNlIGlmICh0eXBlID09PSBQYmYuRml4ZWQ2NCkgdGhpcy5wb3MgKz0gODtcbiAgICAgICAgZWxzZSB0aHJvdyBuZXcgRXJyb3IoJ1VuaW1wbGVtZW50ZWQgdHlwZTogJyArIHR5cGUpO1xuICAgIH0sXG5cbiAgICAvLyA9PT0gV1JJVElORyA9PT09PT09PT09PT09PT09PT09PT09PT09PT09PT09PT09PT09PT09PT09PT09PT09PT09PT09PT09PT09PT09PVxuXG4gICAgd3JpdGVUYWc6IGZ1bmN0aW9uKHRhZywgdHlwZSkge1xuICAgICAgICB0aGlzLndyaXRlVmFyaW50KCh0YWcgPDwgMykgfCB0eXBlKTtcbiAgICB9LFxuXG4gICAgcmVhbGxvYzogZnVuY3Rpb24obWluKSB7XG4gICAgICAgIHZhciBsZW5ndGggPSB0aGlzLmxlbmd0aCB8fCAxNjtcblxuICAgICAgICB3aGlsZSAobGVuZ3RoIDwgdGhpcy5wb3MgKyBtaW4pIGxlbmd0aCAqPSAyO1xuXG4gICAgICAgIGlmIChsZW5ndGggIT09IHRoaXMubGVuZ3RoKSB7XG4gICAgICAgICAgICB2YXIgYnVmID0gbmV3IFVpbnQ4QXJyYXkobGVuZ3RoKTtcbiAgICAgICAgICAgIGJ1Zi5zZXQodGhpcy5idWYpO1xuICAgICAgICAgICAgdGhpcy5idWYgPSBidWY7XG4gICAgICAgICAgICB0aGlzLmxlbmd0aCA9IGxlbmd0aDtcbiAgICAgICAgfVxuICAgIH0sXG5cbiAgICBmaW5pc2g6IGZ1bmN0aW9uKCkge1xuICAgICAgICB0aGlzLmxlbmd0aCA9IHRoaXMucG9zO1xuICAgICAgICB0aGlzLnBvcyA9IDA7XG4gICAgICAgIHJldHVybiB0aGlzLmJ1Zi5zdWJhcnJheSgwLCB0aGlzLmxlbmd0aCk7XG4gICAgfSxcblxuICAgIHdyaXRlRml4ZWQzMjogZnVuY3Rpb24odmFsKSB7XG4gICAgICAgIHRoaXMucmVhbGxvYyg0KTtcbiAgICAgICAgd3JpdGVJbnQzMih0aGlzLmJ1ZiwgdmFsLCB0aGlzLnBvcyk7XG4gICAgICAgIHRoaXMucG9zICs9IDQ7XG4gICAgfSxcblxuICAgIHdyaXRlU0ZpeGVkMzI6IGZ1bmN0aW9uKHZhbCkge1xuICAgICAgICB0aGlzLnJlYWxsb2MoNCk7XG4gICAgICAgIHdyaXRlSW50MzIodGhpcy5idWYsIHZhbCwgdGhpcy5wb3MpO1xuICAgICAgICB0aGlzLnBvcyArPSA0O1xuICAgIH0sXG5cbiAgICB3cml0ZUZpeGVkNjQ6IGZ1bmN0aW9uKHZhbCkge1xuICAgICAgICB0aGlzLnJlYWxsb2MoOCk7XG4gICAgICAgIHdyaXRlSW50MzIodGhpcy5idWYsIHZhbCAmIC0xLCB0aGlzLnBvcyk7XG4gICAgICAgIHdyaXRlSW50MzIodGhpcy5idWYsIE1hdGguZmxvb3IodmFsICogU0hJRlRfUklHSFRfMzIpLCB0aGlzLnBvcyArIDQpO1xuICAgICAgICB0aGlzLnBvcyArPSA4O1xuICAgIH0sXG5cbiAgICB3cml0ZVNGaXhlZDY0OiBmdW5jdGlvbih2YWwpIHtcbiAgICAgICAgdGhpcy5yZWFsbG9jKDgpO1xuICAgICAgICB3cml0ZUludDMyKHRoaXMuYnVmLCB2YWwgJiAtMSwgdGhpcy5wb3MpO1xuICAgICAgICB3cml0ZUludDMyKHRoaXMuYnVmLCBNYXRoLmZsb29yKHZhbCAqIFNISUZUX1JJR0hUXzMyKSwgdGhpcy5wb3MgKyA0KTtcbiAgICAgICAgdGhpcy5wb3MgKz0gODtcbiAgICB9LFxuXG4gICAgd3JpdGVWYXJpbnQ6IGZ1bmN0aW9uKHZhbCkge1xuICAgICAgICB2YWwgPSArdmFsIHx8IDA7XG5cbiAgICAgICAgaWYgKHZhbCA+IDB4ZmZmZmZmZiB8fCB2YWwgPCAwKSB7XG4gICAgICAgICAgICB3cml0ZUJpZ1ZhcmludCh2YWwsIHRoaXMpO1xuICAgICAgICAgICAgcmV0dXJuO1xuICAgICAgICB9XG5cbiAgICAgICAgdGhpcy5yZWFsbG9jKDQpO1xuXG4gICAgICAgIHRoaXMuYnVmW3RoaXMucG9zKytdID0gICAgICAgICAgIHZhbCAmIDB4N2YgIHwgKHZhbCA+IDB4N2YgPyAweDgwIDogMCk7IGlmICh2YWwgPD0gMHg3ZikgcmV0dXJuO1xuICAgICAgICB0aGlzLmJ1Zlt0aGlzLnBvcysrXSA9ICgodmFsID4+Pj0gNykgJiAweDdmKSB8ICh2YWwgPiAweDdmID8gMHg4MCA6IDApOyBpZiAodmFsIDw9IDB4N2YpIHJldHVybjtcbiAgICAgICAgdGhpcy5idWZbdGhpcy5wb3MrK10gPSAoKHZhbCA+Pj49IDcpICYgMHg3ZikgfCAodmFsID4gMHg3ZiA/IDB4ODAgOiAwKTsgaWYgKHZhbCA8PSAweDdmKSByZXR1cm47XG4gICAgICAgIHRoaXMuYnVmW3RoaXMucG9zKytdID0gICAodmFsID4+PiA3KSAmIDB4N2Y7XG4gICAgfSxcblxuICAgIHdyaXRlU1ZhcmludDogZnVuY3Rpb24odmFsKSB7XG4gICAgICAgIHRoaXMud3JpdGVWYXJpbnQodmFsIDwgMCA/IC12YWwgKiAyIC0gMSA6IHZhbCAqIDIpO1xuICAgIH0sXG5cbiAgICB3cml0ZUJvb2xlYW46IGZ1bmN0aW9uKHZhbCkge1xuICAgICAgICB0aGlzLndyaXRlVmFyaW50KEJvb2xlYW4odmFsKSk7XG4gICAgfSxcblxuICAgIHdyaXRlU3RyaW5nOiBmdW5jdGlvbihzdHIpIHtcbiAgICAgICAgc3RyID0gU3RyaW5nKHN0cik7XG4gICAgICAgIHRoaXMucmVhbGxvYyhzdHIubGVuZ3RoICogNCk7XG5cbiAgICAgICAgdGhpcy5wb3MrKzsgLy8gcmVzZXJ2ZSAxIGJ5dGUgZm9yIHNob3J0IHN0cmluZyBsZW5ndGhcblxuICAgICAgICB2YXIgc3RhcnRQb3MgPSB0aGlzLnBvcztcbiAgICAgICAgLy8gd3JpdGUgdGhlIHN0cmluZyBkaXJlY3RseSB0byB0aGUgYnVmZmVyIGFuZCBzZWUgaG93IG11Y2ggd2FzIHdyaXR0ZW5cbiAgICAgICAgdGhpcy5wb3MgPSB3cml0ZVV0ZjgodGhpcy5idWYsIHN0ciwgdGhpcy5wb3MpO1xuICAgICAgICB2YXIgbGVuID0gdGhpcy5wb3MgLSBzdGFydFBvcztcblxuICAgICAgICBpZiAobGVuID49IDB4ODApIG1ha2VSb29tRm9yRXh0cmFMZW5ndGgoc3RhcnRQb3MsIGxlbiwgdGhpcyk7XG5cbiAgICAgICAgLy8gZmluYWxseSwgd3JpdGUgdGhlIG1lc3NhZ2UgbGVuZ3RoIGluIHRoZSByZXNlcnZlZCBwbGFjZSBhbmQgcmVzdG9yZSB0aGUgcG9zaXRpb25cbiAgICAgICAgdGhpcy5wb3MgPSBzdGFydFBvcyAtIDE7XG4gICAgICAgIHRoaXMud3JpdGVWYXJpbnQobGVuKTtcbiAgICAgICAgdGhpcy5wb3MgKz0gbGVuO1xuICAgIH0sXG5cbiAgICB3cml0ZUZsb2F0OiBmdW5jdGlvbih2YWwpIHtcbiAgICAgICAgdGhpcy5yZWFsbG9jKDQpO1xuICAgICAgICBpZWVlNzU0LndyaXRlKHRoaXMuYnVmLCB2YWwsIHRoaXMucG9zLCB0cnVlLCAyMywgNCk7XG4gICAgICAgIHRoaXMucG9zICs9IDQ7XG4gICAgfSxcblxuICAgIHdyaXRlRG91YmxlOiBmdW5jdGlvbih2YWwpIHtcbiAgICAgICAgdGhpcy5yZWFsbG9jKDgpO1xuICAgICAgICBpZWVlNzU0LndyaXRlKHRoaXMuYnVmLCB2YWwsIHRoaXMucG9zLCB0cnVlLCA1MiwgOCk7XG4gICAgICAgIHRoaXMucG9zICs9IDg7XG4gICAgfSxcblxuICAgIHdyaXRlQnl0ZXM6IGZ1bmN0aW9uKGJ1ZmZlcikge1xuICAgICAgICB2YXIgbGVuID0gYnVmZmVyLmxlbmd0aDtcbiAgICAgICAgdGhpcy53cml0ZVZhcmludChsZW4pO1xuICAgICAgICB0aGlzLnJlYWxsb2MobGVuKTtcbiAgICAgICAgZm9yICh2YXIgaSA9IDA7IGkgPCBsZW47IGkrKykgdGhpcy5idWZbdGhpcy5wb3MrK10gPSBidWZmZXJbaV07XG4gICAgfSxcblxuICAgIHdyaXRlUmF3TWVzc2FnZTogZnVuY3Rpb24oZm4sIG9iaikge1xuICAgICAgICB0aGlzLnBvcysrOyAvLyByZXNlcnZlIDEgYnl0ZSBmb3Igc2hvcnQgbWVzc2FnZSBsZW5ndGhcblxuICAgICAgICAvLyB3cml0ZSB0aGUgbWVzc2FnZSBkaXJlY3RseSB0byB0aGUgYnVmZmVyIGFuZCBzZWUgaG93IG11Y2ggd2FzIHdyaXR0ZW5cbiAgICAgICAgdmFyIHN0YXJ0UG9zID0gdGhpcy5wb3M7XG4gICAgICAgIGZuKG9iaiwgdGhpcyk7XG4gICAgICAgIHZhciBsZW4gPSB0aGlzLnBvcyAtIHN0YXJ0UG9zO1xuXG4gICAgICAgIGlmIChsZW4gPj0gMHg4MCkgbWFrZVJvb21Gb3JFeHRyYUxlbmd0aChzdGFydFBvcywgbGVuLCB0aGlzKTtcblxuICAgICAgICAvLyBmaW5hbGx5LCB3cml0ZSB0aGUgbWVzc2FnZSBsZW5ndGggaW4gdGhlIHJlc2VydmVkIHBsYWNlIGFuZCByZXN0b3JlIHRoZSBwb3NpdGlvblxuICAgICAgICB0aGlzLnBvcyA9IHN0YXJ0UG9zIC0gMTtcbiAgICAgICAgdGhpcy53cml0ZVZhcmludChsZW4pO1xuICAgICAgICB0aGlzLnBvcyArPSBsZW47XG4gICAgfSxcblxuICAgIHdyaXRlTWVzc2FnZTogZnVuY3Rpb24odGFnLCBmbiwgb2JqKSB7XG4gICAgICAgIHRoaXMud3JpdGVUYWcodGFnLCBQYmYuQnl0ZXMpO1xuICAgICAgICB0aGlzLndyaXRlUmF3TWVzc2FnZShmbiwgb2JqKTtcbiAgICB9LFxuXG4gICAgd3JpdGVQYWNrZWRWYXJpbnQ6ICAgZnVuY3Rpb24odGFnLCBhcnIpIHsgaWYgKGFyci5sZW5ndGgpIHRoaXMud3JpdGVNZXNzYWdlKHRhZywgd3JpdGVQYWNrZWRWYXJpbnQsIGFycik7ICAgfSxcbiAgICB3cml0ZVBhY2tlZFNWYXJpbnQ6ICBmdW5jdGlvbih0YWcsIGFycikgeyBpZiAoYXJyLmxlbmd0aCkgdGhpcy53cml0ZU1lc3NhZ2UodGFnLCB3cml0ZVBhY2tlZFNWYXJpbnQsIGFycik7ICB9LFxuICAgIHdyaXRlUGFja2VkQm9vbGVhbjogIGZ1bmN0aW9uKHRhZywgYXJyKSB7IGlmIChhcnIubGVuZ3RoKSB0aGlzLndyaXRlTWVzc2FnZSh0YWcsIHdyaXRlUGFja2VkQm9vbGVhbiwgYXJyKTsgIH0sXG4gICAgd3JpdGVQYWNrZWRGbG9hdDogICAgZnVuY3Rpb24odGFnLCBhcnIpIHsgaWYgKGFyci5sZW5ndGgpIHRoaXMud3JpdGVNZXNzYWdlKHRhZywgd3JpdGVQYWNrZWRGbG9hdCwgYXJyKTsgICAgfSxcbiAgICB3cml0ZVBhY2tlZERvdWJsZTogICBmdW5jdGlvbih0YWcsIGFycikgeyBpZiAoYXJyLmxlbmd0aCkgdGhpcy53cml0ZU1lc3NhZ2UodGFnLCB3cml0ZVBhY2tlZERvdWJsZSwgYXJyKTsgICB9LFxuICAgIHdyaXRlUGFja2VkRml4ZWQzMjogIGZ1bmN0aW9uKHRhZywgYXJyKSB7IGlmIChhcnIubGVuZ3RoKSB0aGlzLndyaXRlTWVzc2FnZSh0YWcsIHdyaXRlUGFja2VkRml4ZWQzMiwgYXJyKTsgIH0sXG4gICAgd3JpdGVQYWNrZWRTRml4ZWQzMjogZnVuY3Rpb24odGFnLCBhcnIpIHsgaWYgKGFyci5sZW5ndGgpIHRoaXMud3JpdGVNZXNzYWdlKHRhZywgd3JpdGVQYWNrZWRTRml4ZWQzMiwgYXJyKTsgfSxcbiAgICB3cml0ZVBhY2tlZEZpeGVkNjQ6ICBmdW5jdGlvbih0YWcsIGFycikgeyBpZiAoYXJyLmxlbmd0aCkgdGhpcy53cml0ZU1lc3NhZ2UodGFnLCB3cml0ZVBhY2tlZEZpeGVkNjQsIGFycik7ICB9LFxuICAgIHdyaXRlUGFja2VkU0ZpeGVkNjQ6IGZ1bmN0aW9uKHRhZywgYXJyKSB7IGlmIChhcnIubGVuZ3RoKSB0aGlzLndyaXRlTWVzc2FnZSh0YWcsIHdyaXRlUGFja2VkU0ZpeGVkNjQsIGFycik7IH0sXG5cbiAgICB3cml0ZUJ5dGVzRmllbGQ6IGZ1bmN0aW9uKHRhZywgYnVmZmVyKSB7XG4gICAgICAgIHRoaXMud3JpdGVUYWcodGFnLCBQYmYuQnl0ZXMpO1xuICAgICAgICB0aGlzLndyaXRlQnl0ZXMoYnVmZmVyKTtcbiAgICB9LFxuICAgIHdyaXRlRml4ZWQzMkZpZWxkOiBmdW5jdGlvbih0YWcsIHZhbCkge1xuICAgICAgICB0aGlzLndyaXRlVGFnKHRhZywgUGJmLkZpeGVkMzIpO1xuICAgICAgICB0aGlzLndyaXRlRml4ZWQzMih2YWwpO1xuICAgIH0sXG4gICAgd3JpdGVTRml4ZWQzMkZpZWxkOiBmdW5jdGlvbih0YWcsIHZhbCkge1xuICAgICAgICB0aGlzLndyaXRlVGFnKHRhZywgUGJmLkZpeGVkMzIpO1xuICAgICAgICB0aGlzLndyaXRlU0ZpeGVkMzIodmFsKTtcbiAgICB9LFxuICAgIHdyaXRlRml4ZWQ2NEZpZWxkOiBmdW5jdGlvbih0YWcsIHZhbCkge1xuICAgICAgICB0aGlzLndyaXRlVGFnKHRhZywgUGJmLkZpeGVkNjQpO1xuICAgICAgICB0aGlzLndyaXRlRml4ZWQ2NCh2YWwpO1xuICAgIH0sXG4gICAgd3JpdGVTRml4ZWQ2NEZpZWxkOiBmdW5jdGlvbih0YWcsIHZhbCkge1xuICAgICAgICB0aGlzLndyaXRlVGFnKHRhZywgUGJmLkZpeGVkNjQpO1xuICAgICAgICB0aGlzLndyaXRlU0ZpeGVkNjQodmFsKTtcbiAgICB9LFxuICAgIHdyaXRlVmFyaW50RmllbGQ6IGZ1bmN0aW9uKHRhZywgdmFsKSB7XG4gICAgICAgIHRoaXMud3JpdGVUYWcodGFnLCBQYmYuVmFyaW50KTtcbiAgICAgICAgdGhpcy53cml0ZVZhcmludCh2YWwpO1xuICAgIH0sXG4gICAgd3JpdGVTVmFyaW50RmllbGQ6IGZ1bmN0aW9uKHRhZywgdmFsKSB7XG4gICAgICAgIHRoaXMud3JpdGVUYWcodGFnLCBQYmYuVmFyaW50KTtcbiAgICAgICAgdGhpcy53cml0ZVNWYXJpbnQodmFsKTtcbiAgICB9LFxuICAgIHdyaXRlU3RyaW5nRmllbGQ6IGZ1bmN0aW9uKHRhZywgc3RyKSB7XG4gICAgICAgIHRoaXMud3JpdGVUYWcodGFnLCBQYmYuQnl0ZXMpO1xuICAgICAgICB0aGlzLndyaXRlU3RyaW5nKHN0cik7XG4gICAgfSxcbiAgICB3cml0ZUZsb2F0RmllbGQ6IGZ1bmN0aW9uKHRhZywgdmFsKSB7XG4gICAgICAgIHRoaXMud3JpdGVUYWcodGFnLCBQYmYuRml4ZWQzMik7XG4gICAgICAgIHRoaXMud3JpdGVGbG9hdCh2YWwpO1xuICAgIH0sXG4gICAgd3JpdGVEb3VibGVGaWVsZDogZnVuY3Rpb24odGFnLCB2YWwpIHtcbiAgICAgICAgdGhpcy53cml0ZVRhZyh0YWcsIFBiZi5GaXhlZDY0KTtcbiAgICAgICAgdGhpcy53cml0ZURvdWJsZSh2YWwpO1xuICAgIH0sXG4gICAgd3JpdGVCb29sZWFuRmllbGQ6IGZ1bmN0aW9uKHRhZywgdmFsKSB7XG4gICAgICAgIHRoaXMud3JpdGVWYXJpbnRGaWVsZCh0YWcsIEJvb2xlYW4odmFsKSk7XG4gICAgfVxufTtcblxuZnVuY3Rpb24gcmVhZFZhcmludFJlbWFpbmRlcihsLCBzLCBwKSB7XG4gICAgdmFyIGJ1ZiA9IHAuYnVmLFxuICAgICAgICBoLCBiO1xuXG4gICAgYiA9IGJ1ZltwLnBvcysrXTsgaCAgPSAoYiAmIDB4NzApID4+IDQ7ICBpZiAoYiA8IDB4ODApIHJldHVybiB0b051bShsLCBoLCBzKTtcbiAgICBiID0gYnVmW3AucG9zKytdOyBoIHw9IChiICYgMHg3ZikgPDwgMzsgIGlmIChiIDwgMHg4MCkgcmV0dXJuIHRvTnVtKGwsIGgsIHMpO1xuICAgIGIgPSBidWZbcC5wb3MrK107IGggfD0gKGIgJiAweDdmKSA8PCAxMDsgaWYgKGIgPCAweDgwKSByZXR1cm4gdG9OdW0obCwgaCwgcyk7XG4gICAgYiA9IGJ1ZltwLnBvcysrXTsgaCB8PSAoYiAmIDB4N2YpIDw8IDE3OyBpZiAoYiA8IDB4ODApIHJldHVybiB0b051bShsLCBoLCBzKTtcbiAgICBiID0gYnVmW3AucG9zKytdOyBoIHw9IChiICYgMHg3ZikgPDwgMjQ7IGlmIChiIDwgMHg4MCkgcmV0dXJuIHRvTnVtKGwsIGgsIHMpO1xuICAgIGIgPSBidWZbcC5wb3MrK107IGggfD0gKGIgJiAweDAxKSA8PCAzMTsgaWYgKGIgPCAweDgwKSByZXR1cm4gdG9OdW0obCwgaCwgcyk7XG5cbiAgICB0aHJvdyBuZXcgRXJyb3IoJ0V4cGVjdGVkIHZhcmludCBub3QgbW9yZSB0aGFuIDEwIGJ5dGVzJyk7XG59XG5cbmZ1bmN0aW9uIHJlYWRQYWNrZWRFbmQocGJmKSB7XG4gICAgcmV0dXJuIHBiZi50eXBlID09PSBQYmYuQnl0ZXMgP1xuICAgICAgICBwYmYucmVhZFZhcmludCgpICsgcGJmLnBvcyA6IHBiZi5wb3MgKyAxO1xufVxuXG5mdW5jdGlvbiB0b051bShsb3csIGhpZ2gsIGlzU2lnbmVkKSB7XG4gICAgaWYgKGlzU2lnbmVkKSB7XG4gICAgICAgIHJldHVybiBoaWdoICogMHgxMDAwMDAwMDAgKyAobG93ID4+PiAwKTtcbiAgICB9XG5cbiAgICByZXR1cm4gKChoaWdoID4+PiAwKSAqIDB4MTAwMDAwMDAwKSArIChsb3cgPj4+IDApO1xufVxuXG5mdW5jdGlvbiB3cml0ZUJpZ1ZhcmludCh2YWwsIHBiZikge1xuICAgIHZhciBsb3csIGhpZ2g7XG5cbiAgICBpZiAodmFsID49IDApIHtcbiAgICAgICAgbG93ICA9ICh2YWwgJSAweDEwMDAwMDAwMCkgfCAwO1xuICAgICAgICBoaWdoID0gKHZhbCAvIDB4MTAwMDAwMDAwKSB8IDA7XG4gICAgfSBlbHNlIHtcbiAgICAgICAgbG93ICA9IH4oLXZhbCAlIDB4MTAwMDAwMDAwKTtcbiAgICAgICAgaGlnaCA9IH4oLXZhbCAvIDB4MTAwMDAwMDAwKTtcblxuICAgICAgICBpZiAobG93IF4gMHhmZmZmZmZmZikge1xuICAgICAgICAgICAgbG93ID0gKGxvdyArIDEpIHwgMDtcbiAgICAgICAgfSBlbHNlIHtcbiAgICAgICAgICAgIGxvdyA9IDA7XG4gICAgICAgICAgICBoaWdoID0gKGhpZ2ggKyAxKSB8IDA7XG4gICAgICAgIH1cbiAgICB9XG5cbiAgICBpZiAodmFsID49IDB4MTAwMDAwMDAwMDAwMDAwMDAgfHwgdmFsIDwgLTB4MTAwMDAwMDAwMDAwMDAwMDApIHtcbiAgICAgICAgdGhyb3cgbmV3IEVycm9yKCdHaXZlbiB2YXJpbnQgZG9lc25cXCd0IGZpdCBpbnRvIDEwIGJ5dGVzJyk7XG4gICAgfVxuXG4gICAgcGJmLnJlYWxsb2MoMTApO1xuXG4gICAgd3JpdGVCaWdWYXJpbnRMb3cobG93LCBoaWdoLCBwYmYpO1xuICAgIHdyaXRlQmlnVmFyaW50SGlnaChoaWdoLCBwYmYpO1xufVxuXG5mdW5jdGlvbiB3cml0ZUJpZ1ZhcmludExvdyhsb3csIGhpZ2gsIHBiZikge1xuICAgIHBiZi5idWZbcGJmLnBvcysrXSA9IGxvdyAmIDB4N2YgfCAweDgwOyBsb3cgPj4+PSA3O1xuICAgIHBiZi5idWZbcGJmLnBvcysrXSA9IGxvdyAmIDB4N2YgfCAweDgwOyBsb3cgPj4+PSA3O1xuICAgIHBiZi5idWZbcGJmLnBvcysrXSA9IGxvdyAmIDB4N2YgfCAweDgwOyBsb3cgPj4+PSA3O1xuICAgIHBiZi5idWZbcGJmLnBvcysrXSA9IGxvdyAmIDB4N2YgfCAweDgwOyBsb3cgPj4+PSA3O1xuICAgIHBiZi5idWZbcGJmLnBvc10gICA9IGxvdyAmIDB4N2Y7XG59XG5cbmZ1bmN0aW9uIHdyaXRlQmlnVmFyaW50SGlnaChoaWdoLCBwYmYpIHtcbiAgICB2YXIgbHNiID0gKGhpZ2ggJiAweDA3KSA8PCA0O1xuXG4gICAgcGJmLmJ1ZltwYmYucG9zKytdIHw9IGxzYiAgICAgICAgIHwgKChoaWdoID4+Pj0gMykgPyAweDgwIDogMCk7IGlmICghaGlnaCkgcmV0dXJuO1xuICAgIHBiZi5idWZbcGJmLnBvcysrXSAgPSBoaWdoICYgMHg3ZiB8ICgoaGlnaCA+Pj49IDcpID8gMHg4MCA6IDApOyBpZiAoIWhpZ2gpIHJldHVybjtcbiAgICBwYmYuYnVmW3BiZi5wb3MrK10gID0gaGlnaCAmIDB4N2YgfCAoKGhpZ2ggPj4+PSA3KSA/IDB4ODAgOiAwKTsgaWYgKCFoaWdoKSByZXR1cm47XG4gICAgcGJmLmJ1ZltwYmYucG9zKytdICA9IGhpZ2ggJiAweDdmIHwgKChoaWdoID4+Pj0gNykgPyAweDgwIDogMCk7IGlmICghaGlnaCkgcmV0dXJuO1xuICAgIHBiZi5idWZbcGJmLnBvcysrXSAgPSBoaWdoICYgMHg3ZiB8ICgoaGlnaCA+Pj49IDcpID8gMHg4MCA6IDApOyBpZiAoIWhpZ2gpIHJldHVybjtcbiAgICBwYmYuYnVmW3BiZi5wb3MrK10gID0gaGlnaCAmIDB4N2Y7XG59XG5cbmZ1bmN0aW9uIG1ha2VSb29tRm9yRXh0cmFMZW5ndGgoc3RhcnRQb3MsIGxlbiwgcGJmKSB7XG4gICAgdmFyIGV4dHJhTGVuID1cbiAgICAgICAgbGVuIDw9IDB4M2ZmZiA/IDEgOlxuICAgICAgICBsZW4gPD0gMHgxZmZmZmYgPyAyIDpcbiAgICAgICAgbGVuIDw9IDB4ZmZmZmZmZiA/IDMgOiBNYXRoLmZsb29yKE1hdGgubG9nKGxlbikgLyAoTWF0aC5MTjIgKiA3KSk7XG5cbiAgICAvLyBpZiAxIGJ5dGUgaXNuJ3QgZW5vdWdoIGZvciBlbmNvZGluZyBtZXNzYWdlIGxlbmd0aCwgc2hpZnQgdGhlIGRhdGEgdG8gdGhlIHJpZ2h0XG4gICAgcGJmLnJlYWxsb2MoZXh0cmFMZW4pO1xuICAgIGZvciAodmFyIGkgPSBwYmYucG9zIC0gMTsgaSA+PSBzdGFydFBvczsgaS0tKSBwYmYuYnVmW2kgKyBleHRyYUxlbl0gPSBwYmYuYnVmW2ldO1xufVxuXG5mdW5jdGlvbiB3cml0ZVBhY2tlZFZhcmludChhcnIsIHBiZikgICB7IGZvciAodmFyIGkgPSAwOyBpIDwgYXJyLmxlbmd0aDsgaSsrKSBwYmYud3JpdGVWYXJpbnQoYXJyW2ldKTsgICB9XG5mdW5jdGlvbiB3cml0ZVBhY2tlZFNWYXJpbnQoYXJyLCBwYmYpICB7IGZvciAodmFyIGkgPSAwOyBpIDwgYXJyLmxlbmd0aDsgaSsrKSBwYmYud3JpdGVTVmFyaW50KGFycltpXSk7ICB9XG5mdW5jdGlvbiB3cml0ZVBhY2tlZEZsb2F0KGFyciwgcGJmKSAgICB7IGZvciAodmFyIGkgPSAwOyBpIDwgYXJyLmxlbmd0aDsgaSsrKSBwYmYud3JpdGVGbG9hdChhcnJbaV0pOyAgICB9XG5mdW5jdGlvbiB3cml0ZVBhY2tlZERvdWJsZShhcnIsIHBiZikgICB7IGZvciAodmFyIGkgPSAwOyBpIDwgYXJyLmxlbmd0aDsgaSsrKSBwYmYud3JpdGVEb3VibGUoYXJyW2ldKTsgICB9XG5mdW5jdGlvbiB3cml0ZVBhY2tlZEJvb2xlYW4oYXJyLCBwYmYpICB7IGZvciAodmFyIGkgPSAwOyBpIDwgYXJyLmxlbmd0aDsgaSsrKSBwYmYud3JpdGVCb29sZWFuKGFycltpXSk7ICB9XG5mdW5jdGlvbiB3cml0ZVBhY2tlZEZpeGVkMzIoYXJyLCBwYmYpICB7IGZvciAodmFyIGkgPSAwOyBpIDwgYXJyLmxlbmd0aDsgaSsrKSBwYmYud3JpdGVGaXhlZDMyKGFycltpXSk7ICB9XG5mdW5jdGlvbiB3cml0ZVBhY2tlZFNGaXhlZDMyKGFyciwgcGJmKSB7IGZvciAodmFyIGkgPSAwOyBpIDwgYXJyLmxlbmd0aDsgaSsrKSBwYmYud3JpdGVTRml4ZWQzMihhcnJbaV0pOyB9XG5mdW5jdGlvbiB3cml0ZVBhY2tlZEZpeGVkNjQoYXJyLCBwYmYpICB7IGZvciAodmFyIGkgPSAwOyBpIDwgYXJyLmxlbmd0aDsgaSsrKSBwYmYud3JpdGVGaXhlZDY0KGFycltpXSk7ICB9XG5mdW5jdGlvbiB3cml0ZVBhY2tlZFNGaXhlZDY0KGFyciwgcGJmKSB7IGZvciAodmFyIGkgPSAwOyBpIDwgYXJyLmxlbmd0aDsgaSsrKSBwYmYud3JpdGVTRml4ZWQ2NChhcnJbaV0pOyB9XG5cbi8vIEJ1ZmZlciBjb2RlIGJlbG93IGZyb20gaHR0cHM6Ly9naXRodWIuY29tL2Zlcm9zcy9idWZmZXIsIE1JVC1saWNlbnNlZFxuXG5mdW5jdGlvbiByZWFkVUludDMyKGJ1ZiwgcG9zKSB7XG4gICAgcmV0dXJuICgoYnVmW3Bvc10pIHxcbiAgICAgICAgKGJ1Zltwb3MgKyAxXSA8PCA4KSB8XG4gICAgICAgIChidWZbcG9zICsgMl0gPDwgMTYpKSArXG4gICAgICAgIChidWZbcG9zICsgM10gKiAweDEwMDAwMDApO1xufVxuXG5mdW5jdGlvbiB3cml0ZUludDMyKGJ1ZiwgdmFsLCBwb3MpIHtcbiAgICBidWZbcG9zXSA9IHZhbDtcbiAgICBidWZbcG9zICsgMV0gPSAodmFsID4+PiA4KTtcbiAgICBidWZbcG9zICsgMl0gPSAodmFsID4+PiAxNik7XG4gICAgYnVmW3BvcyArIDNdID0gKHZhbCA+Pj4gMjQpO1xufVxuXG5mdW5jdGlvbiByZWFkSW50MzIoYnVmLCBwb3MpIHtcbiAgICByZXR1cm4gKChidWZbcG9zXSkgfFxuICAgICAgICAoYnVmW3BvcyArIDFdIDw8IDgpIHxcbiAgICAgICAgKGJ1Zltwb3MgKyAyXSA8PCAxNikpICtcbiAgICAgICAgKGJ1Zltwb3MgKyAzXSA8PCAyNCk7XG59XG5cbmZ1bmN0aW9uIHJlYWRVdGY4KGJ1ZiwgcG9zLCBlbmQpIHtcbiAgICB2YXIgc3RyID0gJyc7XG4gICAgdmFyIGkgPSBwb3M7XG5cbiAgICB3aGlsZSAoaSA8IGVuZCkge1xuICAgICAgICB2YXIgYjAgPSBidWZbaV07XG4gICAgICAgIHZhciBjID0gbnVsbDsgLy8gY29kZXBvaW50XG4gICAgICAgIHZhciBieXRlc1BlclNlcXVlbmNlID1cbiAgICAgICAgICAgIGIwID4gMHhFRiA/IDQgOlxuICAgICAgICAgICAgYjAgPiAweERGID8gMyA6XG4gICAgICAgICAgICBiMCA+IDB4QkYgPyAyIDogMTtcblxuICAgICAgICBpZiAoaSArIGJ5dGVzUGVyU2VxdWVuY2UgPiBlbmQpIGJyZWFrO1xuXG4gICAgICAgIHZhciBiMSwgYjIsIGIzO1xuXG4gICAgICAgIGlmIChieXRlc1BlclNlcXVlbmNlID09PSAxKSB7XG4gICAgICAgICAgICBpZiAoYjAgPCAweDgwKSB7XG4gICAgICAgICAgICAgICAgYyA9IGIwO1xuICAgICAgICAgICAgfVxuICAgICAgICB9IGVsc2UgaWYgKGJ5dGVzUGVyU2VxdWVuY2UgPT09IDIpIHtcbiAgICAgICAgICAgIGIxID0gYnVmW2kgKyAxXTtcbiAgICAgICAgICAgIGlmICgoYjEgJiAweEMwKSA9PT0gMHg4MCkge1xuICAgICAgICAgICAgICAgIGMgPSAoYjAgJiAweDFGKSA8PCAweDYgfCAoYjEgJiAweDNGKTtcbiAgICAgICAgICAgICAgICBpZiAoYyA8PSAweDdGKSB7XG4gICAgICAgICAgICAgICAgICAgIGMgPSBudWxsO1xuICAgICAgICAgICAgICAgIH1cbiAgICAgICAgICAgIH1cbiAgICAgICAgfSBlbHNlIGlmIChieXRlc1BlclNlcXVlbmNlID09PSAzKSB7XG4gICAgICAgICAgICBiMSA9IGJ1ZltpICsgMV07XG4gICAgICAgICAgICBiMiA9IGJ1ZltpICsgMl07XG4gICAgICAgICAgICBpZiAoKGIxICYgMHhDMCkgPT09IDB4ODAgJiYgKGIyICYgMHhDMCkgPT09IDB4ODApIHtcbiAgICAgICAgICAgICAgICBjID0gKGIwICYgMHhGKSA8PCAweEMgfCAoYjEgJiAweDNGKSA8PCAweDYgfCAoYjIgJiAweDNGKTtcbiAgICAgICAgICAgICAgICBpZiAoYyA8PSAweDdGRiB8fCAoYyA+PSAweEQ4MDAgJiYgYyA8PSAweERGRkYpKSB7XG4gICAgICAgICAgICAgICAgICAgIGMgPSBudWxsO1xuICAgICAgICAgICAgICAgIH1cbiAgICAgICAgICAgIH1cbiAgICAgICAgfSBlbHNlIGlmIChieXRlc1BlclNlcXVlbmNlID09PSA0KSB7XG4gICAgICAgICAgICBiMSA9IGJ1ZltpICsgMV07XG4gICAgICAgICAgICBiMiA9IGJ1ZltpICsgMl07XG4gICAgICAgICAgICBiMyA9IGJ1ZltpICsgM107XG4gICAgICAgICAgICBpZiAoKGIxICYgMHhDMCkgPT09IDB4ODAgJiYgKGIyICYgMHhDMCkgPT09IDB4ODAgJiYgKGIzICYgMHhDMCkgPT09IDB4ODApIHtcbiAgICAgICAgICAgICAgICBjID0gKGIwICYgMHhGKSA8PCAweDEyIHwgKGIxICYgMHgzRikgPDwgMHhDIHwgKGIyICYgMHgzRikgPDwgMHg2IHwgKGIzICYgMHgzRik7XG4gICAgICAgICAgICAgICAgaWYgKGMgPD0gMHhGRkZGIHx8IGMgPj0gMHgxMTAwMDApIHtcbiAgICAgICAgICAgICAgICAgICAgYyA9IG51bGw7XG4gICAgICAgICAgICAgICAgfVxuICAgICAgICAgICAgfVxuICAgICAgICB9XG5cbiAgICAgICAgaWYgKGMgPT09IG51bGwpIHtcbiAgICAgICAgICAgIGMgPSAweEZGRkQ7XG4gICAgICAgICAgICBieXRlc1BlclNlcXVlbmNlID0gMTtcblxuICAgICAgICB9IGVsc2UgaWYgKGMgPiAweEZGRkYpIHtcbiAgICAgICAgICAgIGMgLT0gMHgxMDAwMDtcbiAgICAgICAgICAgIHN0ciArPSBTdHJpbmcuZnJvbUNoYXJDb2RlKGMgPj4+IDEwICYgMHgzRkYgfCAweEQ4MDApO1xuICAgICAgICAgICAgYyA9IDB4REMwMCB8IGMgJiAweDNGRjtcbiAgICAgICAgfVxuXG4gICAgICAgIHN0ciArPSBTdHJpbmcuZnJvbUNoYXJDb2RlKGMpO1xuICAgICAgICBpICs9IGJ5dGVzUGVyU2VxdWVuY2U7XG4gICAgfVxuXG4gICAgcmV0dXJuIHN0cjtcbn1cblxuZnVuY3Rpb24gcmVhZFV0ZjhUZXh0RGVjb2RlcihidWYsIHBvcywgZW5kKSB7XG4gICAgcmV0dXJuIHV0ZjhUZXh0RGVjb2Rlci5kZWNvZGUoYnVmLnN1YmFycmF5KHBvcywgZW5kKSk7XG59XG5cbmZ1bmN0aW9uIHdyaXRlVXRmOChidWYsIHN0ciwgcG9zKSB7XG4gICAgZm9yICh2YXIgaSA9IDAsIGMsIGxlYWQ7IGkgPCBzdHIubGVuZ3RoOyBpKyspIHtcbiAgICAgICAgYyA9IHN0ci5jaGFyQ29kZUF0KGkpOyAvLyBjb2RlIHBvaW50XG5cbiAgICAgICAgaWYgKGMgPiAweEQ3RkYgJiYgYyA8IDB4RTAwMCkge1xuICAgICAgICAgICAgaWYgKGxlYWQpIHtcbiAgICAgICAgICAgICAgICBpZiAoYyA8IDB4REMwMCkge1xuICAgICAgICAgICAgICAgICAgICBidWZbcG9zKytdID0gMHhFRjtcbiAgICAgICAgICAgICAgICAgICAgYnVmW3BvcysrXSA9IDB4QkY7XG4gICAgICAgICAgICAgICAgICAgIGJ1Zltwb3MrK10gPSAweEJEO1xuICAgICAgICAgICAgICAgICAgICBsZWFkID0gYztcbiAgICAgICAgICAgICAgICAgICAgY29udGludWU7XG4gICAgICAgICAgICAgICAgfSBlbHNlIHtcbiAgICAgICAgICAgICAgICAgICAgYyA9IGxlYWQgLSAweEQ4MDAgPDwgMTAgfCBjIC0gMHhEQzAwIHwgMHgxMDAwMDtcbiAgICAgICAgICAgICAgICAgICAgbGVhZCA9IG51bGw7XG4gICAgICAgICAgICAgICAgfVxuICAgICAgICAgICAgfSBlbHNlIHtcbiAgICAgICAgICAgICAgICBpZiAoYyA+IDB4REJGRiB8fCAoaSArIDEgPT09IHN0ci5sZW5ndGgpKSB7XG4gICAgICAgICAgICAgICAgICAgIGJ1Zltwb3MrK10gPSAweEVGO1xuICAgICAgICAgICAgICAgICAgICBidWZbcG9zKytdID0gMHhCRjtcbiAgICAgICAgICAgICAgICAgICAgYnVmW3BvcysrXSA9IDB4QkQ7XG4gICAgICAgICAgICAgICAgfSBlbHNlIHtcbiAgICAgICAgICAgICAgICAgICAgbGVhZCA9IGM7XG4gICAgICAgICAgICAgICAgfVxuICAgICAgICAgICAgICAgIGNvbnRpbnVlO1xuICAgICAgICAgICAgfVxuICAgICAgICB9IGVsc2UgaWYgKGxlYWQpIHtcbiAgICAgICAgICAgIGJ1Zltwb3MrK10gPSAweEVGO1xuICAgICAgICAgICAgYnVmW3BvcysrXSA9IDB4QkY7XG4gICAgICAgICAgICBidWZbcG9zKytdID0gMHhCRDtcbiAgICAgICAgICAgIGxlYWQgPSBudWxsO1xuICAgICAgICB9XG5cbiAgICAgICAgaWYgKGMgPCAweDgwKSB7XG4gICAgICAgICAgICBidWZbcG9zKytdID0gYztcbiAgICAgICAgfSBlbHNlIHtcbiAgICAgICAgICAgIGlmIChjIDwgMHg4MDApIHtcbiAgICAgICAgICAgICAgICBidWZbcG9zKytdID0gYyA+PiAweDYgfCAweEMwO1xuICAgICAgICAgICAgfSBlbHNlIHtcbiAgICAgICAgICAgICAgICBpZiAoYyA8IDB4MTAwMDApIHtcbiAgICAgICAgICAgICAgICAgICAgYnVmW3BvcysrXSA9IGMgPj4gMHhDIHwgMHhFMDtcbiAgICAgICAgICAgICAgICB9IGVsc2Uge1xuICAgICAgICAgICAgICAgICAgICBidWZbcG9zKytdID0gYyA+PiAweDEyIHwgMHhGMDtcbiAgICAgICAgICAgICAgICAgICAgYnVmW3BvcysrXSA9IGMgPj4gMHhDICYgMHgzRiB8IDB4ODA7XG4gICAgICAgICAgICAgICAgfVxuICAgICAgICAgICAgICAgIGJ1Zltwb3MrK10gPSBjID4+IDB4NiAmIDB4M0YgfCAweDgwO1xuICAgICAgICAgICAgfVxuICAgICAgICAgICAgYnVmW3BvcysrXSA9IGMgJiAweDNGIHwgMHg4MDtcbiAgICAgICAgfVxuICAgIH1cbiAgICByZXR1cm4gcG9zO1xufVxuIiwiLyohIGllZWU3NTQuIEJTRC0zLUNsYXVzZSBMaWNlbnNlLiBGZXJvc3MgQWJvdWtoYWRpamVoIDxodHRwczovL2Zlcm9zcy5vcmcvb3BlbnNvdXJjZT4gKi9cbmV4cG9ydHMucmVhZCA9IGZ1bmN0aW9uIChidWZmZXIsIG9mZnNldCwgaXNMRSwgbUxlbiwgbkJ5dGVzKSB7XG4gIHZhciBlLCBtXG4gIHZhciBlTGVuID0gKG5CeXRlcyAqIDgpIC0gbUxlbiAtIDFcbiAgdmFyIGVNYXggPSAoMSA8PCBlTGVuKSAtIDFcbiAgdmFyIGVCaWFzID0gZU1heCA+PiAxXG4gIHZhciBuQml0cyA9IC03XG4gIHZhciBpID0gaXNMRSA/IChuQnl0ZXMgLSAxKSA6IDBcbiAgdmFyIGQgPSBpc0xFID8gLTEgOiAxXG4gIHZhciBzID0gYnVmZmVyW29mZnNldCArIGldXG5cbiAgaSArPSBkXG5cbiAgZSA9IHMgJiAoKDEgPDwgKC1uQml0cykpIC0gMSlcbiAgcyA+Pj0gKC1uQml0cylcbiAgbkJpdHMgKz0gZUxlblxuICBmb3IgKDsgbkJpdHMgPiAwOyBlID0gKGUgKiAyNTYpICsgYnVmZmVyW29mZnNldCArIGldLCBpICs9IGQsIG5CaXRzIC09IDgpIHt9XG5cbiAgbSA9IGUgJiAoKDEgPDwgKC1uQml0cykpIC0gMSlcbiAgZSA+Pj0gKC1uQml0cylcbiAgbkJpdHMgKz0gbUxlblxuICBmb3IgKDsgbkJpdHMgPiAwOyBtID0gKG0gKiAyNTYpICsgYnVmZmVyW29mZnNldCArIGldLCBpICs9IGQsIG5CaXRzIC09IDgpIHt9XG5cbiAgaWYgKGUgPT09IDApIHtcbiAgICBlID0gMSAtIGVCaWFzXG4gIH0gZWxzZSBpZiAoZSA9PT0gZU1heCkge1xuICAgIHJldHVybiBtID8gTmFOIDogKChzID8gLTEgOiAxKSAqIEluZmluaXR5KVxuICB9IGVsc2Uge1xuICAgIG0gPSBtICsgTWF0aC5wb3coMiwgbUxlbilcbiAgICBlID0gZSAtIGVCaWFzXG4gIH1cbiAgcmV0dXJuIChzID8gLTEgOiAxKSAqIG0gKiBNYXRoLnBvdygyLCBlIC0gbUxlbilcbn1cblxuZXhwb3J0cy53cml0ZSA9IGZ1bmN0aW9uIChidWZmZXIsIHZhbHVlLCBvZmZzZXQsIGlzTEUsIG1MZW4sIG5CeXRlcykge1xuICB2YXIgZSwgbSwgY1xuICB2YXIgZUxlbiA9IChuQnl0ZXMgKiA4KSAtIG1MZW4gLSAxXG4gIHZhciBlTWF4ID0gKDEgPDwgZUxlbikgLSAxXG4gIHZhciBlQmlhcyA9IGVNYXggPj4gMVxuICB2YXIgcnQgPSAobUxlbiA9PT0gMjMgPyBNYXRoLnBvdygyLCAtMjQpIC0gTWF0aC5wb3coMiwgLTc3KSA6IDApXG4gIHZhciBpID0gaXNMRSA/IDAgOiAobkJ5dGVzIC0gMSlcbiAgdmFyIGQgPSBpc0xFID8gMSA6IC0xXG4gIHZhciBzID0gdmFsdWUgPCAwIHx8ICh2YWx1ZSA9PT0gMCAmJiAxIC8gdmFsdWUgPCAwKSA/IDEgOiAwXG5cbiAgdmFsdWUgPSBNYXRoLmFicyh2YWx1ZSlcblxuICBpZiAoaXNOYU4odmFsdWUpIHx8IHZhbHVlID09PSBJbmZpbml0eSkge1xuICAgIG0gPSBpc05hTih2YWx1ZSkgPyAxIDogMFxuICAgIGUgPSBlTWF4XG4gIH0gZWxzZSB7XG4gICAgZSA9IE1hdGguZmxvb3IoTWF0aC5sb2codmFsdWUpIC8gTWF0aC5MTjIpXG4gICAgaWYgKHZhbHVlICogKGMgPSBNYXRoLnBvdygyLCAtZSkpIDwgMSkge1xuICAgICAgZS0tXG4gICAgICBjICo9IDJcbiAgICB9XG4gICAgaWYgKGUgKyBlQmlhcyA+PSAxKSB7XG4gICAgICB2YWx1ZSArPSBydCAvIGNcbiAgICB9IGVsc2Uge1xuICAgICAgdmFsdWUgKz0gcnQgKiBNYXRoLnBvdygyLCAxIC0gZUJpYXMpXG4gICAgfVxuICAgIGlmICh2YWx1ZSAqIGMgPj0gMikge1xuICAgICAgZSsrXG4gICAgICBjIC89IDJcbiAgICB9XG5cbiAgICBpZiAoZSArIGVCaWFzID49IGVNYXgpIHtcbiAgICAgIG0gPSAwXG4gICAgICBlID0gZU1heFxuICAgIH0gZWxzZSBpZiAoZSArIGVCaWFzID49IDEpIHtcbiAgICAgIG0gPSAoKHZhbHVlICogYykgLSAxKSAqIE1hdGgucG93KDIsIG1MZW4pXG4gICAgICBlID0gZSArIGVCaWFzXG4gICAgfSBlbHNlIHtcbiAgICAgIG0gPSB2YWx1ZSAqIE1hdGgucG93KDIsIGVCaWFzIC0gMSkgKiBNYXRoLnBvdygyLCBtTGVuKVxuICAgICAgZSA9IDBcbiAgICB9XG4gIH1cblxuICBmb3IgKDsgbUxlbiA+PSA4OyBidWZmZXJbb2Zmc2V0ICsgaV0gPSBtICYgMHhmZiwgaSArPSBkLCBtIC89IDI1NiwgbUxlbiAtPSA4KSB7fVxuXG4gIGUgPSAoZSA8PCBtTGVuKSB8IG1cbiAgZUxlbiArPSBtTGVuXG4gIGZvciAoOyBlTGVuID4gMDsgYnVmZmVyW29mZnNldCArIGldID0gZSAmIDB4ZmYsIGkgKz0gZCwgZSAvPSAyNTYsIGVMZW4gLT0gOCkge31cblxuICBidWZmZXJbb2Zmc2V0ICsgaSAtIGRdIHw9IHMgKiAxMjhcbn1cbiJdfQ== | ||
| })); |
@@ -1,1 +0,1 @@ | ||
| !function(t){"object"==typeof exports&&"undefined"!=typeof module?module.exports=t():"function"==typeof define&&define.amd?define([],t):("undefined"!=typeof window?window:"undefined"!=typeof global?global:"undefined"!=typeof self?self:this).Pbf=t()}(function(){return function r(s,n,o){function h(i,t){if(!n[i]){if(!s[i]){var e="function"==typeof require&&require;if(!t&&e)return e(i,!0);if(a)return a(i,!0);throw(t=new Error("Cannot find module '"+i+"'")).code="MODULE_NOT_FOUND",t}e=n[i]={exports:{}},s[i][0].call(e.exports,function(t){return h(s[i][1][t]||t)},e,e.exports,r,s,n,o)}return n[i].exports}for(var a="function"==typeof require&&require,t=0;t<o.length;t++)h(o[t]);return h}({1:[function(t,i,e){i.exports=s;var r=t("ieee754");function s(t){this.buf=ArrayBuffer.isView&&ArrayBuffer.isView(t)?t:new Uint8Array(t||0),this.pos=0,this.type=0,this.length=this.buf.length}s.Varint=0,s.Fixed64=1,s.Bytes=2,s.Fixed32=5;var n=4294967296,o=1/n,l="undefined"==typeof TextDecoder?null:new TextDecoder("utf-8");function h(t){return t.type===s.Bytes?t.readVarint()+t.pos:t.pos+1}function a(t,i,e){return e?4294967296*i+(t>>>0):4294967296*(i>>>0)+(t>>>0)}function u(t,i,e){var r=i<=16383?1:i<=2097151?2:i<=268435455?3:Math.floor(Math.log(i)/(7*Math.LN2));e.realloc(r);for(var s=e.pos-1;t<=s;s--)e.buf[s+r]=e.buf[s]}function f(t,i){for(var e=0;e<t.length;e++)i.writeVarint(t[e])}function d(t,i){for(var e=0;e<t.length;e++)i.writeSVarint(t[e])}function p(t,i){for(var e=0;e<t.length;e++)i.writeFloat(t[e])}function c(t,i){for(var e=0;e<t.length;e++)i.writeDouble(t[e])}function w(t,i){for(var e=0;e<t.length;e++)i.writeBoolean(t[e])}function F(t,i){for(var e=0;e<t.length;e++)i.writeFixed32(t[e])}function b(t,i){for(var e=0;e<t.length;e++)i.writeSFixed32(t[e])}function g(t,i){for(var e=0;e<t.length;e++)i.writeFixed64(t[e])}function x(t,i){for(var e=0;e<t.length;e++)i.writeSFixed64(t[e])}function y(t,i){return(t[i]|t[i+1]<<8|t[i+2]<<16)+16777216*t[i+3]}function v(t,i,e){t[e]=i,t[e+1]=i>>>8,t[e+2]=i>>>16,t[e+3]=i>>>24}function V(t,i){return(t[i]|t[i+1]<<8|t[i+2]<<16)+(t[i+3]<<24)}s.prototype={destroy:function(){this.buf=null},readFields:function(t,i,e){for(e=e||this.length;this.pos<e;){var r=this.readVarint(),s=r>>3,n=this.pos;this.type=7&r,t(s,i,this),this.pos===n&&this.skip(r)}return i},readMessage:function(t,i){return this.readFields(t,i,this.readVarint()+this.pos)},readFixed32:function(){var t=y(this.buf,this.pos);return this.pos+=4,t},readSFixed32:function(){var t=V(this.buf,this.pos);return this.pos+=4,t},readFixed64:function(){var t=y(this.buf,this.pos)+y(this.buf,this.pos+4)*n;return this.pos+=8,t},readSFixed64:function(){var t=y(this.buf,this.pos)+V(this.buf,this.pos+4)*n;return this.pos+=8,t},readFloat:function(){var t=r.read(this.buf,this.pos,!0,23,4);return this.pos+=4,t},readDouble:function(){var t=r.read(this.buf,this.pos,!0,52,8);return this.pos+=8,t},readVarint:function(t){var i=this.buf,e=i[this.pos++],r=127&e;if(e<128)return r;if(r|=(127&(e=i[this.pos++]))<<7,e<128)return r;if(r|=(127&(e=i[this.pos++]))<<14,e<128)return r;if(r|=(127&(e=i[this.pos++]))<<21,e<128)return r;var s,n,e=r|=(15&i[this.pos])<<28,i=t,r=this,t=r.buf;if(n=t[r.pos++],s=(112&n)>>4,n<128)return a(e,s,i);if(n=t[r.pos++],s|=(127&n)<<3,n<128)return a(e,s,i);if(n=t[r.pos++],s|=(127&n)<<10,n<128)return a(e,s,i);if(n=t[r.pos++],s|=(127&n)<<17,n<128)return a(e,s,i);if(n=t[r.pos++],s|=(127&n)<<24,n<128)return a(e,s,i);if(n=t[r.pos++],s|=(1&n)<<31,n<128)return a(e,s,i);throw new Error("Expected varint not more than 10 bytes")},readVarint64:function(){return this.readVarint(!0)},readSVarint:function(){var t=this.readVarint();return t%2==1?(t+1)/-2:t/2},readBoolean:function(){return Boolean(this.readVarint())},readString:function(){var t=this.readVarint()+this.pos,i=this.pos;if(12<=(this.pos=t)-i&&l)return e=this.buf,l.decode(e.subarray(i,t));for(var e,r,s,n,o=this.buf,h=t,a="",u=i;u<h;){var f=o[u],d=null,p=239<f?4:223<f?3:191<f?2:1;if(h<u+p)break;1===p?f<128&&(d=f):2===p?128==(192&(r=o[u+1]))&&(d=(31&f)<<6|63&r)<=127&&(d=null):3===p?(r=o[u+1],s=o[u+2],128==(192&r)&&128==(192&s)&&((d=(15&f)<<12|(63&r)<<6|63&s)<=2047||55296<=d&&d<=57343)&&(d=null)):4===p&&(r=o[u+1],s=o[u+2],n=o[u+3],128==(192&r))&&128==(192&s)&&128==(192&n)&&((d=(15&f)<<18|(63&r)<<12|(63&s)<<6|63&n)<=65535||1114112<=d)&&(d=null),null===d?(d=65533,p=1):65535<d&&(d-=65536,a+=String.fromCharCode(d>>>10&1023|55296),d=56320|1023&d),a+=String.fromCharCode(d),u+=p}return a},readBytes:function(){var t=this.readVarint()+this.pos,i=this.buf.subarray(this.pos,t);return this.pos=t,i},readPackedVarint:function(t,i){if(this.type!==s.Bytes)return t.push(this.readVarint(i));var e=h(this);for(t=t||[];this.pos<e;)t.push(this.readVarint(i));return t},readPackedSVarint:function(t){if(this.type!==s.Bytes)return t.push(this.readSVarint());var i=h(this);for(t=t||[];this.pos<i;)t.push(this.readSVarint());return t},readPackedBoolean:function(t){if(this.type!==s.Bytes)return t.push(this.readBoolean());var i=h(this);for(t=t||[];this.pos<i;)t.push(this.readBoolean());return t},readPackedFloat:function(t){if(this.type!==s.Bytes)return t.push(this.readFloat());var i=h(this);for(t=t||[];this.pos<i;)t.push(this.readFloat());return t},readPackedDouble:function(t){if(this.type!==s.Bytes)return t.push(this.readDouble());var i=h(this);for(t=t||[];this.pos<i;)t.push(this.readDouble());return t},readPackedFixed32:function(t){if(this.type!==s.Bytes)return t.push(this.readFixed32());var i=h(this);for(t=t||[];this.pos<i;)t.push(this.readFixed32());return t},readPackedSFixed32:function(t){if(this.type!==s.Bytes)return t.push(this.readSFixed32());var i=h(this);for(t=t||[];this.pos<i;)t.push(this.readSFixed32());return t},readPackedFixed64:function(t){if(this.type!==s.Bytes)return t.push(this.readFixed64());var i=h(this);for(t=t||[];this.pos<i;)t.push(this.readFixed64());return t},readPackedSFixed64:function(t){if(this.type!==s.Bytes)return t.push(this.readSFixed64());var i=h(this);for(t=t||[];this.pos<i;)t.push(this.readSFixed64());return t},skip:function(t){t&=7;if(t===s.Varint)for(;127<this.buf[this.pos++];);else if(t===s.Bytes)this.pos=this.readVarint()+this.pos;else if(t===s.Fixed32)this.pos+=4;else{if(t!==s.Fixed64)throw new Error("Unimplemented type: "+t);this.pos+=8}},writeTag:function(t,i){this.writeVarint(t<<3|i)},realloc:function(t){for(var i,e=this.length||16;e<this.pos+t;)e*=2;e!==this.length&&((i=new Uint8Array(e)).set(this.buf),this.buf=i,this.length=e)},finish:function(){return this.length=this.pos,this.pos=0,this.buf.subarray(0,this.length)},writeFixed32:function(t){this.realloc(4),v(this.buf,t,this.pos),this.pos+=4},writeSFixed32:function(t){this.realloc(4),v(this.buf,t,this.pos),this.pos+=4},writeFixed64:function(t){this.realloc(8),v(this.buf,-1&t,this.pos),v(this.buf,Math.floor(t*o),this.pos+4),this.pos+=8},writeSFixed64:function(t){this.realloc(8),v(this.buf,-1&t,this.pos),v(this.buf,Math.floor(t*o),this.pos+4),this.pos+=8},writeVarint:function(t){if(268435455<(t=+t||0)||t<0){var i=t,e=this;if(0<=i?(r=i%4294967296|0,s=i/4294967296|0):(s=~(-i/4294967296),4294967295^(r=~(-i%4294967296))?r=r+1|0:s=s+1|(r=0)),0x10000000000000000<=i||i<-0x10000000000000000)throw new Error("Given varint doesn't fit into 10 bytes");e.realloc(10);var i=r,r=e,i=(r.buf[r.pos++]=127&i|128,i>>>=7,r.buf[r.pos++]=127&i|128,i>>>=7,r.buf[r.pos++]=127&i|128,i>>>=7,r.buf[r.pos++]=127&i|128,i>>>=7,r.buf[r.pos]=127&i,s),s=e,e=(7&i)<<4;s.buf[s.pos++]|=e|((i>>>=3)?128:0),i&&(s.buf[s.pos++]=127&i|((i>>>=7)?128:0),i)&&(s.buf[s.pos++]=127&i|((i>>>=7)?128:0),i)&&(s.buf[s.pos++]=127&i|((i>>>=7)?128:0),i)&&(s.buf[s.pos++]=127&i|((i>>>=7)?128:0),i)&&(s.buf[s.pos++]=127&i)}else this.realloc(4),this.buf[this.pos++]=127&t|(127<t?128:0),t<=127||(this.buf[this.pos++]=127&(t>>>=7)|(127<t?128:0),t<=127)||(this.buf[this.pos++]=127&(t>>>=7)|(127<t?128:0),t<=127)||(this.buf[this.pos++]=t>>>7&127)},writeSVarint:function(t){this.writeVarint(t<0?2*-t-1:2*t)},writeBoolean:function(t){this.writeVarint(Boolean(t))},writeString:function(t){t=String(t),this.realloc(4*t.length),this.pos++;var i=this.pos,t=(this.pos=function(t,i,e){for(var r,s,n=0;n<i.length;n++){if(55295<(r=i.charCodeAt(n))&&r<57344){if(!s){56319<r||n+1===i.length?(t[e++]=239,t[e++]=191,t[e++]=189):s=r;continue}if(r<56320){t[e++]=239,t[e++]=191,t[e++]=189,s=r;continue}r=s-55296<<10|r-56320|65536,s=null}else s&&(t[e++]=239,t[e++]=191,t[e++]=189,s=null);r<128?t[e++]=r:(r<2048?t[e++]=r>>6|192:(r<65536?t[e++]=r>>12|224:(t[e++]=r>>18|240,t[e++]=r>>12&63|128),t[e++]=r>>6&63|128),t[e++]=63&r|128)}return e}(this.buf,t,this.pos),this.pos-i);128<=t&&u(i,t,this),this.pos=i-1,this.writeVarint(t),this.pos+=t},writeFloat:function(t){this.realloc(4),r.write(this.buf,t,this.pos,!0,23,4),this.pos+=4},writeDouble:function(t){this.realloc(8),r.write(this.buf,t,this.pos,!0,52,8),this.pos+=8},writeBytes:function(t){var i=t.length;this.writeVarint(i),this.realloc(i);for(var e=0;e<i;e++)this.buf[this.pos++]=t[e]},writeRawMessage:function(t,i){this.pos++;var e=this.pos,t=(t(i,this),this.pos-e);128<=t&&u(e,t,this),this.pos=e-1,this.writeVarint(t),this.pos+=t},writeMessage:function(t,i,e){this.writeTag(t,s.Bytes),this.writeRawMessage(i,e)},writePackedVarint:function(t,i){i.length&&this.writeMessage(t,f,i)},writePackedSVarint:function(t,i){i.length&&this.writeMessage(t,d,i)},writePackedBoolean:function(t,i){i.length&&this.writeMessage(t,w,i)},writePackedFloat:function(t,i){i.length&&this.writeMessage(t,p,i)},writePackedDouble:function(t,i){i.length&&this.writeMessage(t,c,i)},writePackedFixed32:function(t,i){i.length&&this.writeMessage(t,F,i)},writePackedSFixed32:function(t,i){i.length&&this.writeMessage(t,b,i)},writePackedFixed64:function(t,i){i.length&&this.writeMessage(t,g,i)},writePackedSFixed64:function(t,i){i.length&&this.writeMessage(t,x,i)},writeBytesField:function(t,i){this.writeTag(t,s.Bytes),this.writeBytes(i)},writeFixed32Field:function(t,i){this.writeTag(t,s.Fixed32),this.writeFixed32(i)},writeSFixed32Field:function(t,i){this.writeTag(t,s.Fixed32),this.writeSFixed32(i)},writeFixed64Field:function(t,i){this.writeTag(t,s.Fixed64),this.writeFixed64(i)},writeSFixed64Field:function(t,i){this.writeTag(t,s.Fixed64),this.writeSFixed64(i)},writeVarintField:function(t,i){this.writeTag(t,s.Varint),this.writeVarint(i)},writeSVarintField:function(t,i){this.writeTag(t,s.Varint),this.writeSVarint(i)},writeStringField:function(t,i){this.writeTag(t,s.Bytes),this.writeString(i)},writeFloatField:function(t,i){this.writeTag(t,s.Fixed32),this.writeFloat(i)},writeDoubleField:function(t,i){this.writeTag(t,s.Fixed64),this.writeDouble(i)},writeBooleanField:function(t,i){this.writeVarintField(t,Boolean(i))}}},{ieee754:2}],2:[function(t,i,e){e.read=function(t,i,e,r,s){var n,o,h=8*s-r-1,a=(1<<h)-1,u=a>>1,f=-7,d=e?s-1:0,p=e?-1:1,s=t[i+d];for(d+=p,n=s&(1<<-f)-1,s>>=-f,f+=h;0<f;n=256*n+t[i+d],d+=p,f-=8);for(o=n&(1<<-f)-1,n>>=-f,f+=r;0<f;o=256*o+t[i+d],d+=p,f-=8);if(0===n)n=1-u;else{if(n===a)return o?NaN:1/0*(s?-1:1);o+=Math.pow(2,r),n-=u}return(s?-1:1)*o*Math.pow(2,n-r)},e.write=function(t,i,e,r,s,n){var o,h,a=8*n-s-1,u=(1<<a)-1,f=u>>1,d=23===s?Math.pow(2,-24)-Math.pow(2,-77):0,p=r?0:n-1,l=r?1:-1,n=i<0||0===i&&1/i<0?1:0;for(i=Math.abs(i),isNaN(i)||i===1/0?(h=isNaN(i)?1:0,o=u):(o=Math.floor(Math.log(i)/Math.LN2),i*(r=Math.pow(2,-o))<1&&(o--,r*=2),2<=(i+=1<=o+f?d/r:d*Math.pow(2,1-f))*r&&(o++,r/=2),u<=o+f?(h=0,o=u):1<=o+f?(h=(i*r-1)*Math.pow(2,s),o+=f):(h=i*Math.pow(2,f-1)*Math.pow(2,s),o=0));8<=s;t[e+p]=255&h,p+=l,h/=256,s-=8);for(o=o<<s|h,a+=s;0<a;t[e+p]=255&o,p+=l,o/=256,a-=8);t[e+p-l]|=128*n}},{}]},{},[1])(1)}); | ||
| !function(t,i){"object"==typeof exports&&"undefined"!=typeof module?module.exports=i():"function"==typeof define&&define.amd?define(i):(t="undefined"!=typeof globalThis?globalThis:t||self).Pbf=i()}(this,(function(){"use strict";const t=4294967296,i=1/t,e="undefined"==typeof TextDecoder?null:new TextDecoder("utf-8");function s(t,i,e){return e?4294967296*i+(t>>>0):4294967296*(i>>>0)+(t>>>0)}function r(t,i,e){const s=i<=16383?1:i<=2097151?2:i<=268435455?3:Math.floor(Math.log(i)/(7*Math.LN2));e.realloc(s);for(let i=e.pos-1;i>=t;i--)e.buf[i+s]=e.buf[i]}function o(t,i){for(let e=0;e<t.length;e++)i.writeVarint(t[e])}function h(t,i){for(let e=0;e<t.length;e++)i.writeSVarint(t[e])}function n(t,i){for(let e=0;e<t.length;e++)i.writeFloat(t[e])}function a(t,i){for(let e=0;e<t.length;e++)i.writeDouble(t[e])}function d(t,i){for(let e=0;e<t.length;e++)i.writeBoolean(t[e])}function l(t,i){for(let e=0;e<t.length;e++)i.writeFixed32(t[e])}function u(t,i){for(let e=0;e<t.length;e++)i.writeSFixed32(t[e])}function f(t,i){for(let e=0;e<t.length;e++)i.writeFixed64(t[e])}function p(t,i){for(let e=0;e<t.length;e++)i.writeSFixed64(t[e])}return class{constructor(t){this.buf=ArrayBuffer.isView&&ArrayBuffer.isView(t)?t:new Uint8Array(t||0),this.dataView=new DataView(this.buf.buffer),this.pos=0,this.type=0,this.length=this.buf.length}readFields(t,i,e=this.length){for(;this.pos<e;){const e=this.readVarint(),s=e>>3,r=this.pos;this.type=7&e,t(s,i,this),this.pos===r&&this.skip(e)}return i}readMessage(t,i){return this.readFields(t,i,this.readVarint()+this.pos)}readFixed32(){const t=this.dataView.getUint32(this.pos,!0);return this.pos+=4,t}readSFixed32(){const t=this.dataView.getInt32(this.pos,!0);return this.pos+=4,t}readFixed64(){const i=this.dataView.getUint32(this.pos,!0)+this.dataView.getUint32(this.pos+4,!0)*t;return this.pos+=8,i}readSFixed64(){const i=this.dataView.getUint32(this.pos,!0)+this.dataView.getInt32(this.pos+4,!0)*t;return this.pos+=8,i}readFloat(){const t=this.dataView.getFloat32(this.pos,!0);return this.pos+=4,t}readDouble(){const t=this.dataView.getFloat64(this.pos,!0);return this.pos+=8,t}readVarint(t){const i=this.buf;let e,r;return r=i[this.pos++],e=127&r,r<128?e:(r=i[this.pos++],e|=(127&r)<<7,r<128?e:(r=i[this.pos++],e|=(127&r)<<14,r<128?e:(r=i[this.pos++],e|=(127&r)<<21,r<128?e:(r=i[this.pos],e|=(15&r)<<28,function(t,i,e){const r=e.buf;let o,h;if(h=r[e.pos++],o=(112&h)>>4,h<128)return s(t,o,i);if(h=r[e.pos++],o|=(127&h)<<3,h<128)return s(t,o,i);if(h=r[e.pos++],o|=(127&h)<<10,h<128)return s(t,o,i);if(h=r[e.pos++],o|=(127&h)<<17,h<128)return s(t,o,i);if(h=r[e.pos++],o|=(127&h)<<24,h<128)return s(t,o,i);if(h=r[e.pos++],o|=(1&h)<<31,h<128)return s(t,o,i);throw new Error("Expected varint not more than 10 bytes")}(e,t,this)))))}readVarint64(){return this.readVarint(!0)}readSVarint(){const t=this.readVarint();return t%2==1?(t+1)/-2:t/2}readBoolean(){return Boolean(this.readVarint())}readString(){const t=this.readVarint()+this.pos,i=this.pos;return this.pos=t,t-i>=12&&e?e.decode(this.buf.subarray(i,t)):function(t,i,e){let s="",r=i;for(;r<e;){const i=t[r];let o,h,n,a=null,d=i>239?4:i>223?3:i>191?2:1;if(r+d>e)break;1===d?i<128&&(a=i):2===d?(o=t[r+1],128==(192&o)&&(a=(31&i)<<6|63&o,a<=127&&(a=null))):3===d?(o=t[r+1],h=t[r+2],128==(192&o)&&128==(192&h)&&(a=(15&i)<<12|(63&o)<<6|63&h,(a<=2047||a>=55296&&a<=57343)&&(a=null))):4===d&&(o=t[r+1],h=t[r+2],n=t[r+3],128==(192&o)&&128==(192&h)&&128==(192&n)&&(a=(15&i)<<18|(63&o)<<12|(63&h)<<6|63&n,(a<=65535||a>=1114112)&&(a=null))),null===a?(a=65533,d=1):a>65535&&(a-=65536,s+=String.fromCharCode(a>>>10&1023|55296),a=56320|1023&a),s+=String.fromCharCode(a),r+=d}return s}(this.buf,i,t)}readBytes(){const t=this.readVarint()+this.pos,i=this.buf.subarray(this.pos,t);return this.pos=t,i}readPackedVarint(t=[],i){const e=this.readPackedEnd();for(;this.pos<e;)t.push(this.readVarint(i));return t}readPackedSVarint(t=[]){const i=this.readPackedEnd();for(;this.pos<i;)t.push(this.readSVarint());return t}readPackedBoolean(t=[]){const i=this.readPackedEnd();for(;this.pos<i;)t.push(this.readBoolean());return t}readPackedFloat(t=[]){const i=this.readPackedEnd();for(;this.pos<i;)t.push(this.readFloat());return t}readPackedDouble(t=[]){const i=this.readPackedEnd();for(;this.pos<i;)t.push(this.readDouble());return t}readPackedFixed32(t=[]){const i=this.readPackedEnd();for(;this.pos<i;)t.push(this.readFixed32());return t}readPackedSFixed32(t=[]){const i=this.readPackedEnd();for(;this.pos<i;)t.push(this.readSFixed32());return t}readPackedFixed64(t=[]){const i=this.readPackedEnd();for(;this.pos<i;)t.push(this.readFixed64());return t}readPackedSFixed64(t=[]){const i=this.readPackedEnd();for(;this.pos<i;)t.push(this.readSFixed64());return t}readPackedEnd(){return 2===this.type?this.readVarint()+this.pos:this.pos+1}skip(t){const i=7&t;if(0===i)for(;this.buf[this.pos++]>127;);else if(2===i)this.pos=this.readVarint()+this.pos;else if(5===i)this.pos+=4;else{if(1!==i)throw new Error(`Unimplemented type: ${i}`);this.pos+=8}}writeTag(t,i){this.writeVarint(t<<3|i)}realloc(t){let i=this.length||16;for(;i<this.pos+t;)i*=2;if(i!==this.length){const t=new Uint8Array(i);t.set(this.buf),this.buf=t,this.dataView=new DataView(t.buffer),this.length=i}}finish(){return this.length=this.pos,this.pos=0,this.buf.subarray(0,this.length)}writeFixed32(t){this.realloc(4),this.dataView.setInt32(this.pos,t,!0),this.pos+=4}writeSFixed32(t){this.realloc(4),this.dataView.setInt32(this.pos,t,!0),this.pos+=4}writeFixed64(t){this.realloc(8),this.dataView.setInt32(this.pos,-1&t,!0),this.dataView.setInt32(this.pos+4,Math.floor(t*i),!0),this.pos+=8}writeSFixed64(t){this.realloc(8),this.dataView.setInt32(this.pos,-1&t,!0),this.dataView.setInt32(this.pos+4,Math.floor(t*i),!0),this.pos+=8}writeVarint(t){(t=+t||0)>268435455||t<0?function(t,i){let e,s;t>=0?(e=t%4294967296|0,s=t/4294967296|0):(e=~(-t%4294967296),s=~(-t/4294967296),4294967295^e?e=e+1|0:(e=0,s=s+1|0));if(t>=0x10000000000000000||t<-0x10000000000000000)throw new Error("Given varint doesn't fit into 10 bytes");i.realloc(10),function(t,i,e){e.buf[e.pos++]=127&t|128,t>>>=7,e.buf[e.pos++]=127&t|128,t>>>=7,e.buf[e.pos++]=127&t|128,t>>>=7,e.buf[e.pos++]=127&t|128,t>>>=7,e.buf[e.pos]=127&t}(e,0,i),function(t,i){const e=(7&t)<<4;if(i.buf[i.pos++]|=e|((t>>>=3)?128:0),!t)return;if(i.buf[i.pos++]=127&t|((t>>>=7)?128:0),!t)return;if(i.buf[i.pos++]=127&t|((t>>>=7)?128:0),!t)return;if(i.buf[i.pos++]=127&t|((t>>>=7)?128:0),!t)return;if(i.buf[i.pos++]=127&t|((t>>>=7)?128:0),!t)return;i.buf[i.pos++]=127&t}(s,i)}(t,this):(this.realloc(4),this.buf[this.pos++]=127&t|(t>127?128:0),t<=127||(this.buf[this.pos++]=127&(t>>>=7)|(t>127?128:0),t<=127||(this.buf[this.pos++]=127&(t>>>=7)|(t>127?128:0),t<=127||(this.buf[this.pos++]=t>>>7&127))))}writeSVarint(t){this.writeVarint(t<0?2*-t-1:2*t)}writeBoolean(t){this.writeVarint(+t)}writeString(t){t=String(t),this.realloc(4*t.length),this.pos++;const i=this.pos;this.pos=function(t,i,e){for(let s,r,o=0;o<i.length;o++){if(s=i.charCodeAt(o),s>55295&&s<57344){if(!r){s>56319||o+1===i.length?(t[e++]=239,t[e++]=191,t[e++]=189):r=s;continue}if(s<56320){t[e++]=239,t[e++]=191,t[e++]=189,r=s;continue}s=r-55296<<10|s-56320|65536,r=null}else r&&(t[e++]=239,t[e++]=191,t[e++]=189,r=null);s<128?t[e++]=s:(s<2048?t[e++]=s>>6|192:(s<65536?t[e++]=s>>12|224:(t[e++]=s>>18|240,t[e++]=s>>12&63|128),t[e++]=s>>6&63|128),t[e++]=63&s|128)}return e}(this.buf,t,this.pos);const e=this.pos-i;e>=128&&r(i,e,this),this.pos=i-1,this.writeVarint(e),this.pos+=e}writeFloat(t){this.realloc(4),this.dataView.setFloat32(this.pos,t,!0),this.pos+=4}writeDouble(t){this.realloc(8),this.dataView.setFloat64(this.pos,t,!0),this.pos+=8}writeBytes(t){const i=t.length;this.writeVarint(i),this.realloc(i);for(let e=0;e<i;e++)this.buf[this.pos++]=t[e]}writeRawMessage(t,i){this.pos++;const e=this.pos;t(i,this);const s=this.pos-e;s>=128&&r(e,s,this),this.pos=e-1,this.writeVarint(s),this.pos+=s}writeMessage(t,i,e){this.writeTag(t,2),this.writeRawMessage(i,e)}writePackedVarint(t,i){i.length&&this.writeMessage(t,o,i)}writePackedSVarint(t,i){i.length&&this.writeMessage(t,h,i)}writePackedBoolean(t,i){i.length&&this.writeMessage(t,d,i)}writePackedFloat(t,i){i.length&&this.writeMessage(t,n,i)}writePackedDouble(t,i){i.length&&this.writeMessage(t,a,i)}writePackedFixed32(t,i){i.length&&this.writeMessage(t,l,i)}writePackedSFixed32(t,i){i.length&&this.writeMessage(t,u,i)}writePackedFixed64(t,i){i.length&&this.writeMessage(t,f,i)}writePackedSFixed64(t,i){i.length&&this.writeMessage(t,p,i)}writeBytesField(t,i){this.writeTag(t,2),this.writeBytes(i)}writeFixed32Field(t,i){this.writeTag(t,5),this.writeFixed32(i)}writeSFixed32Field(t,i){this.writeTag(t,5),this.writeSFixed32(i)}writeFixed64Field(t,i){this.writeTag(t,1),this.writeFixed64(i)}writeSFixed64Field(t,i){this.writeTag(t,1),this.writeSFixed64(i)}writeVarintField(t,i){this.writeTag(t,0),this.writeVarint(i)}writeSVarintField(t,i){this.writeTag(t,0),this.writeSVarint(i)}writeStringField(t,i){this.writeTag(t,2),this.writeString(i)}writeFloatField(t,i){this.writeTag(t,5),this.writeFloat(i)}writeDoubleField(t,i){this.writeTag(t,1),this.writeDouble(i)}writeBooleanField(t,i){this.writeVarintField(t,+i)}}})); |
726
index.js
@@ -1,40 +0,38 @@ | ||
| 'use strict'; | ||
| module.exports = Pbf; | ||
| const SHIFT_LEFT_32 = (1 << 16) * (1 << 16); | ||
| const SHIFT_RIGHT_32 = 1 / SHIFT_LEFT_32; | ||
| var ieee754 = require('ieee754'); | ||
| function Pbf(buf) { | ||
| this.buf = ArrayBuffer.isView && ArrayBuffer.isView(buf) ? buf : new Uint8Array(buf || 0); | ||
| this.pos = 0; | ||
| this.type = 0; | ||
| this.length = this.buf.length; | ||
| } | ||
| Pbf.Varint = 0; // varint: int32, int64, uint32, uint64, sint32, sint64, bool, enum | ||
| Pbf.Fixed64 = 1; // 64-bit: double, fixed64, sfixed64 | ||
| Pbf.Bytes = 2; // length-delimited: string, bytes, embedded messages, packed repeated fields | ||
| Pbf.Fixed32 = 5; // 32-bit: float, fixed32, sfixed32 | ||
| var SHIFT_LEFT_32 = (1 << 16) * (1 << 16), | ||
| SHIFT_RIGHT_32 = 1 / SHIFT_LEFT_32; | ||
| // Threshold chosen based on both benchmarking and knowledge about browser string | ||
| // data structures (which currently switch structure types at 12 bytes or more) | ||
| var TEXT_DECODER_MIN_LENGTH = 12; | ||
| var utf8TextDecoder = typeof TextDecoder === 'undefined' ? null : new TextDecoder('utf-8'); | ||
| const TEXT_DECODER_MIN_LENGTH = 12; | ||
| const utf8TextDecoder = typeof TextDecoder === 'undefined' ? null : new TextDecoder('utf-8'); | ||
| Pbf.prototype = { | ||
| const PBF_VARINT = 0; // varint: int32, int64, uint32, uint64, sint32, sint64, bool, enum | ||
| const PBF_FIXED64 = 1; // 64-bit: double, fixed64, sfixed64 | ||
| const PBF_BYTES = 2; // length-delimited: string, bytes, embedded messages, packed repeated fields | ||
| const PBF_FIXED32 = 5; // 32-bit: float, fixed32, sfixed32 | ||
| destroy: function() { | ||
| this.buf = null; | ||
| }, | ||
| export default class Pbf { | ||
| /** | ||
| * @param {Uint8Array | ArrayBuffer} buf | ||
| */ | ||
| constructor(buf) { | ||
| this.buf = ArrayBuffer.isView && ArrayBuffer.isView(buf) ? buf : new Uint8Array(buf || 0); | ||
| this.dataView = new DataView(this.buf.buffer); | ||
| this.pos = 0; | ||
| this.type = 0; | ||
| this.length = this.buf.length; | ||
| } | ||
| // === READING ================================================================= | ||
| readFields: function(readField, result, end) { | ||
| end = end || this.length; | ||
| /** | ||
| * @template T | ||
| * @param {(tag: number, result: T, pbf: Pbf) => void} readField | ||
| * @param {T} result | ||
| * @param {number} [end] | ||
| */ | ||
| readFields(readField, result, end = this.length) { | ||
| while (this.pos < end) { | ||
| var val = this.readVarint(), | ||
| const val = this.readVarint(), | ||
| tag = val >> 3, | ||
@@ -49,49 +47,57 @@ startPos = this.pos; | ||
| return result; | ||
| }, | ||
| } | ||
| readMessage: function(readField, result) { | ||
| /** | ||
| * @template T | ||
| * @param {(tag: number, result: T, pbf: Pbf) => void} readField | ||
| * @param {T} result | ||
| */ | ||
| readMessage(readField, result) { | ||
| return this.readFields(readField, result, this.readVarint() + this.pos); | ||
| }, | ||
| } | ||
| readFixed32: function() { | ||
| var val = readUInt32(this.buf, this.pos); | ||
| readFixed32() { | ||
| const val = this.dataView.getUint32(this.pos, true); | ||
| this.pos += 4; | ||
| return val; | ||
| }, | ||
| } | ||
| readSFixed32: function() { | ||
| var val = readInt32(this.buf, this.pos); | ||
| readSFixed32() { | ||
| const val = this.dataView.getInt32(this.pos, true); | ||
| this.pos += 4; | ||
| return val; | ||
| }, | ||
| } | ||
| // 64-bit int handling is based on github.com/dpw/node-buffer-more-ints (MIT-licensed) | ||
| readFixed64: function() { | ||
| var val = readUInt32(this.buf, this.pos) + readUInt32(this.buf, this.pos + 4) * SHIFT_LEFT_32; | ||
| readFixed64() { | ||
| const val = this.dataView.getUint32(this.pos, true) + this.dataView.getUint32(this.pos + 4, true) * SHIFT_LEFT_32; | ||
| this.pos += 8; | ||
| return val; | ||
| }, | ||
| } | ||
| readSFixed64: function() { | ||
| var val = readUInt32(this.buf, this.pos) + readInt32(this.buf, this.pos + 4) * SHIFT_LEFT_32; | ||
| readSFixed64() { | ||
| const val = this.dataView.getUint32(this.pos, true) + this.dataView.getInt32(this.pos + 4, true) * SHIFT_LEFT_32; | ||
| this.pos += 8; | ||
| return val; | ||
| }, | ||
| } | ||
| readFloat: function() { | ||
| var val = ieee754.read(this.buf, this.pos, true, 23, 4); | ||
| readFloat() { | ||
| const val = this.dataView.getFloat32(this.pos, true); | ||
| this.pos += 4; | ||
| return val; | ||
| }, | ||
| } | ||
| readDouble: function() { | ||
| var val = ieee754.read(this.buf, this.pos, true, 52, 8); | ||
| readDouble() { | ||
| const val = this.dataView.getFloat64(this.pos, true); | ||
| this.pos += 8; | ||
| return val; | ||
| }, | ||
| } | ||
| readVarint: function(isSigned) { | ||
| var buf = this.buf, | ||
| val, b; | ||
| /** | ||
| * @param {boolean} [isSigned] | ||
| */ | ||
| readVarint(isSigned) { | ||
| const buf = this.buf; | ||
| let val, b; | ||
@@ -105,20 +111,20 @@ b = buf[this.pos++]; val = b & 0x7f; if (b < 0x80) return val; | ||
| return readVarintRemainder(val, isSigned, this); | ||
| }, | ||
| } | ||
| readVarint64: function() { // for compatibility with v2.0.1 | ||
| readVarint64() { // for compatibility with v2.0.1 | ||
| return this.readVarint(true); | ||
| }, | ||
| } | ||
| readSVarint: function() { | ||
| var num = this.readVarint(); | ||
| readSVarint() { | ||
| const num = this.readVarint(); | ||
| return num % 2 === 1 ? (num + 1) / -2 : num / 2; // zigzag encoding | ||
| }, | ||
| } | ||
| readBoolean: function() { | ||
| readBoolean() { | ||
| return Boolean(this.readVarint()); | ||
| }, | ||
| } | ||
| readString: function() { | ||
| var end = this.readVarint() + this.pos; | ||
| var pos = this.pos; | ||
| readString() { | ||
| const end = this.readVarint() + this.pos; | ||
| const pos = this.pos; | ||
| this.pos = end; | ||
@@ -128,98 +134,101 @@ | ||
| // longer strings are fast with the built-in browser TextDecoder API | ||
| return readUtf8TextDecoder(this.buf, pos, end); | ||
| return utf8TextDecoder.decode(this.buf.subarray(pos, end)); | ||
| } | ||
| // short strings are fast with our custom implementation | ||
| return readUtf8(this.buf, pos, end); | ||
| }, | ||
| } | ||
| readBytes: function() { | ||
| var end = this.readVarint() + this.pos, | ||
| readBytes() { | ||
| const end = this.readVarint() + this.pos, | ||
| buffer = this.buf.subarray(this.pos, end); | ||
| this.pos = end; | ||
| return buffer; | ||
| }, | ||
| } | ||
| // verbose for performance reasons; doesn't affect gzipped size | ||
| readPackedVarint: function(arr, isSigned) { | ||
| if (this.type !== Pbf.Bytes) return arr.push(this.readVarint(isSigned)); | ||
| var end = readPackedEnd(this); | ||
| arr = arr || []; | ||
| /** | ||
| * @param {number[]} [arr] | ||
| * @param {boolean} [isSigned] | ||
| */ | ||
| readPackedVarint(arr = [], isSigned) { | ||
| const end = this.readPackedEnd(); | ||
| while (this.pos < end) arr.push(this.readVarint(isSigned)); | ||
| return arr; | ||
| }, | ||
| readPackedSVarint: function(arr) { | ||
| if (this.type !== Pbf.Bytes) return arr.push(this.readSVarint()); | ||
| var end = readPackedEnd(this); | ||
| arr = arr || []; | ||
| } | ||
| /** @param {number[]} [arr] */ | ||
| readPackedSVarint(arr = []) { | ||
| const end = this.readPackedEnd(); | ||
| while (this.pos < end) arr.push(this.readSVarint()); | ||
| return arr; | ||
| }, | ||
| readPackedBoolean: function(arr) { | ||
| if (this.type !== Pbf.Bytes) return arr.push(this.readBoolean()); | ||
| var end = readPackedEnd(this); | ||
| arr = arr || []; | ||
| } | ||
| /** @param {boolean[]} [arr] */ | ||
| readPackedBoolean(arr = []) { | ||
| const end = this.readPackedEnd(); | ||
| while (this.pos < end) arr.push(this.readBoolean()); | ||
| return arr; | ||
| }, | ||
| readPackedFloat: function(arr) { | ||
| if (this.type !== Pbf.Bytes) return arr.push(this.readFloat()); | ||
| var end = readPackedEnd(this); | ||
| arr = arr || []; | ||
| } | ||
| /** @param {number[]} [arr] */ | ||
| readPackedFloat(arr = []) { | ||
| const end = this.readPackedEnd(); | ||
| while (this.pos < end) arr.push(this.readFloat()); | ||
| return arr; | ||
| }, | ||
| readPackedDouble: function(arr) { | ||
| if (this.type !== Pbf.Bytes) return arr.push(this.readDouble()); | ||
| var end = readPackedEnd(this); | ||
| arr = arr || []; | ||
| } | ||
| /** @param {number[]} [arr] */ | ||
| readPackedDouble(arr = []) { | ||
| const end = this.readPackedEnd(); | ||
| while (this.pos < end) arr.push(this.readDouble()); | ||
| return arr; | ||
| }, | ||
| readPackedFixed32: function(arr) { | ||
| if (this.type !== Pbf.Bytes) return arr.push(this.readFixed32()); | ||
| var end = readPackedEnd(this); | ||
| arr = arr || []; | ||
| } | ||
| /** @param {number[]} [arr] */ | ||
| readPackedFixed32(arr = []) { | ||
| const end = this.readPackedEnd(); | ||
| while (this.pos < end) arr.push(this.readFixed32()); | ||
| return arr; | ||
| }, | ||
| readPackedSFixed32: function(arr) { | ||
| if (this.type !== Pbf.Bytes) return arr.push(this.readSFixed32()); | ||
| var end = readPackedEnd(this); | ||
| arr = arr || []; | ||
| } | ||
| /** @param {number[]} [arr] */ | ||
| readPackedSFixed32(arr = []) { | ||
| const end = this.readPackedEnd(); | ||
| while (this.pos < end) arr.push(this.readSFixed32()); | ||
| return arr; | ||
| }, | ||
| readPackedFixed64: function(arr) { | ||
| if (this.type !== Pbf.Bytes) return arr.push(this.readFixed64()); | ||
| var end = readPackedEnd(this); | ||
| arr = arr || []; | ||
| } | ||
| /** @param {number[]} [arr] */ | ||
| readPackedFixed64(arr = []) { | ||
| const end = this.readPackedEnd(); | ||
| while (this.pos < end) arr.push(this.readFixed64()); | ||
| return arr; | ||
| }, | ||
| readPackedSFixed64: function(arr) { | ||
| if (this.type !== Pbf.Bytes) return arr.push(this.readSFixed64()); | ||
| var end = readPackedEnd(this); | ||
| arr = arr || []; | ||
| } | ||
| /** @param {number[]} [arr] */ | ||
| readPackedSFixed64(arr = []) { | ||
| const end = this.readPackedEnd(); | ||
| while (this.pos < end) arr.push(this.readSFixed64()); | ||
| return arr; | ||
| }, | ||
| } | ||
| readPackedEnd() { | ||
| return this.type === PBF_BYTES ? this.readVarint() + this.pos : this.pos + 1; | ||
| } | ||
| skip: function(val) { | ||
| var type = val & 0x7; | ||
| if (type === Pbf.Varint) while (this.buf[this.pos++] > 0x7f) {} | ||
| else if (type === Pbf.Bytes) this.pos = this.readVarint() + this.pos; | ||
| else if (type === Pbf.Fixed32) this.pos += 4; | ||
| else if (type === Pbf.Fixed64) this.pos += 8; | ||
| else throw new Error('Unimplemented type: ' + type); | ||
| }, | ||
| /** @param {number} val */ | ||
| skip(val) { | ||
| const type = val & 0x7; | ||
| if (type === PBF_VARINT) while (this.buf[this.pos++] > 0x7f) {} | ||
| else if (type === PBF_BYTES) this.pos = this.readVarint() + this.pos; | ||
| else if (type === PBF_FIXED32) this.pos += 4; | ||
| else if (type === PBF_FIXED64) this.pos += 8; | ||
| else throw new Error(`Unimplemented type: ${type}`); | ||
| } | ||
| // === WRITING ================================================================= | ||
| writeTag: function(tag, type) { | ||
| /** | ||
| * @param {number} tag | ||
| * @param {number} type | ||
| */ | ||
| writeTag(tag, type) { | ||
| this.writeVarint((tag << 3) | type); | ||
| }, | ||
| } | ||
| realloc: function(min) { | ||
| var length = this.length || 16; | ||
| /** @param {number} min */ | ||
| realloc(min) { | ||
| let length = this.length || 16; | ||
@@ -229,42 +238,48 @@ while (length < this.pos + min) length *= 2; | ||
| if (length !== this.length) { | ||
| var buf = new Uint8Array(length); | ||
| const buf = new Uint8Array(length); | ||
| buf.set(this.buf); | ||
| this.buf = buf; | ||
| this.dataView = new DataView(buf.buffer); | ||
| this.length = length; | ||
| } | ||
| }, | ||
| } | ||
| finish: function() { | ||
| finish() { | ||
| this.length = this.pos; | ||
| this.pos = 0; | ||
| return this.buf.subarray(0, this.length); | ||
| }, | ||
| } | ||
| writeFixed32: function(val) { | ||
| /** @param {number} val */ | ||
| writeFixed32(val) { | ||
| this.realloc(4); | ||
| writeInt32(this.buf, val, this.pos); | ||
| this.dataView.setInt32(this.pos, val, true); | ||
| this.pos += 4; | ||
| }, | ||
| } | ||
| writeSFixed32: function(val) { | ||
| /** @param {number} val */ | ||
| writeSFixed32(val) { | ||
| this.realloc(4); | ||
| writeInt32(this.buf, val, this.pos); | ||
| this.dataView.setInt32(this.pos, val, true); | ||
| this.pos += 4; | ||
| }, | ||
| } | ||
| writeFixed64: function(val) { | ||
| /** @param {number} val */ | ||
| writeFixed64(val) { | ||
| this.realloc(8); | ||
| writeInt32(this.buf, val & -1, this.pos); | ||
| writeInt32(this.buf, Math.floor(val * SHIFT_RIGHT_32), this.pos + 4); | ||
| this.dataView.setInt32(this.pos, val & -1, true); | ||
| this.dataView.setInt32(this.pos + 4, Math.floor(val * SHIFT_RIGHT_32), true); | ||
| this.pos += 8; | ||
| }, | ||
| } | ||
| writeSFixed64: function(val) { | ||
| /** @param {number} val */ | ||
| writeSFixed64(val) { | ||
| this.realloc(8); | ||
| writeInt32(this.buf, val & -1, this.pos); | ||
| writeInt32(this.buf, Math.floor(val * SHIFT_RIGHT_32), this.pos + 4); | ||
| this.dataView.setInt32(this.pos, val & -1, true); | ||
| this.dataView.setInt32(this.pos + 4, Math.floor(val * SHIFT_RIGHT_32), true); | ||
| this.pos += 8; | ||
| }, | ||
| } | ||
| writeVarint: function(val) { | ||
| /** @param {number} val */ | ||
| writeVarint(val) { | ||
| val = +val || 0; | ||
@@ -283,13 +298,16 @@ | ||
| this.buf[this.pos++] = (val >>> 7) & 0x7f; | ||
| }, | ||
| } | ||
| writeSVarint: function(val) { | ||
| /** @param {number} val */ | ||
| writeSVarint(val) { | ||
| this.writeVarint(val < 0 ? -val * 2 - 1 : val * 2); | ||
| }, | ||
| } | ||
| writeBoolean: function(val) { | ||
| this.writeVarint(Boolean(val)); | ||
| }, | ||
| /** @param {boolean} val */ | ||
| writeBoolean(val) { | ||
| this.writeVarint(+val); | ||
| } | ||
| writeString: function(str) { | ||
| /** @param {string} str */ | ||
| writeString(str) { | ||
| str = String(str); | ||
@@ -300,6 +318,6 @@ this.realloc(str.length * 4); | ||
| var startPos = this.pos; | ||
| const startPos = this.pos; | ||
| // write the string directly to the buffer and see how much was written | ||
| this.pos = writeUtf8(this.buf, str, this.pos); | ||
| var len = this.pos - startPos; | ||
| const len = this.pos - startPos; | ||
@@ -312,30 +330,38 @@ if (len >= 0x80) makeRoomForExtraLength(startPos, len, this); | ||
| this.pos += len; | ||
| }, | ||
| } | ||
| writeFloat: function(val) { | ||
| /** @param {number} val */ | ||
| writeFloat(val) { | ||
| this.realloc(4); | ||
| ieee754.write(this.buf, val, this.pos, true, 23, 4); | ||
| this.dataView.setFloat32(this.pos, val, true); | ||
| this.pos += 4; | ||
| }, | ||
| } | ||
| writeDouble: function(val) { | ||
| /** @param {number} val */ | ||
| writeDouble(val) { | ||
| this.realloc(8); | ||
| ieee754.write(this.buf, val, this.pos, true, 52, 8); | ||
| this.dataView.setFloat64(this.pos, val, true); | ||
| this.pos += 8; | ||
| }, | ||
| } | ||
| writeBytes: function(buffer) { | ||
| var len = buffer.length; | ||
| /** @param {Uint8Array} buffer */ | ||
| writeBytes(buffer) { | ||
| const len = buffer.length; | ||
| this.writeVarint(len); | ||
| this.realloc(len); | ||
| for (var i = 0; i < len; i++) this.buf[this.pos++] = buffer[i]; | ||
| }, | ||
| for (let i = 0; i < len; i++) this.buf[this.pos++] = buffer[i]; | ||
| } | ||
| writeRawMessage: function(fn, obj) { | ||
| /** | ||
| * @template T | ||
| * @param {(obj: T, pbf: Pbf) => void} fn | ||
| * @param {T} obj | ||
| */ | ||
| writeRawMessage(fn, obj) { | ||
| this.pos++; // reserve 1 byte for short message length | ||
| // write the message directly to the buffer and see how much was written | ||
| var startPos = this.pos; | ||
| const startPos = this.pos; | ||
| fn(obj, this); | ||
| var len = this.pos - startPos; | ||
| const len = this.pos - startPos; | ||
@@ -348,67 +374,176 @@ if (len >= 0x80) makeRoomForExtraLength(startPos, len, this); | ||
| this.pos += len; | ||
| }, | ||
| } | ||
| writeMessage: function(tag, fn, obj) { | ||
| this.writeTag(tag, Pbf.Bytes); | ||
| /** | ||
| * @template T | ||
| * @param {number} tag | ||
| * @param {(obj: T, pbf: Pbf) => void} fn | ||
| * @param {T} obj | ||
| */ | ||
| writeMessage(tag, fn, obj) { | ||
| this.writeTag(tag, PBF_BYTES); | ||
| this.writeRawMessage(fn, obj); | ||
| }, | ||
| } | ||
| writePackedVarint: function(tag, arr) { if (arr.length) this.writeMessage(tag, writePackedVarint, arr); }, | ||
| writePackedSVarint: function(tag, arr) { if (arr.length) this.writeMessage(tag, writePackedSVarint, arr); }, | ||
| writePackedBoolean: function(tag, arr) { if (arr.length) this.writeMessage(tag, writePackedBoolean, arr); }, | ||
| writePackedFloat: function(tag, arr) { if (arr.length) this.writeMessage(tag, writePackedFloat, arr); }, | ||
| writePackedDouble: function(tag, arr) { if (arr.length) this.writeMessage(tag, writePackedDouble, arr); }, | ||
| writePackedFixed32: function(tag, arr) { if (arr.length) this.writeMessage(tag, writePackedFixed32, arr); }, | ||
| writePackedSFixed32: function(tag, arr) { if (arr.length) this.writeMessage(tag, writePackedSFixed32, arr); }, | ||
| writePackedFixed64: function(tag, arr) { if (arr.length) this.writeMessage(tag, writePackedFixed64, arr); }, | ||
| writePackedSFixed64: function(tag, arr) { if (arr.length) this.writeMessage(tag, writePackedSFixed64, arr); }, | ||
| /** | ||
| * @param {number} tag | ||
| * @param {number[]} arr | ||
| */ | ||
| writePackedVarint(tag, arr) { | ||
| if (arr.length) this.writeMessage(tag, writePackedVarint, arr); | ||
| } | ||
| /** | ||
| * @param {number} tag | ||
| * @param {number[]} arr | ||
| */ | ||
| writePackedSVarint(tag, arr) { | ||
| if (arr.length) this.writeMessage(tag, writePackedSVarint, arr); | ||
| } | ||
| /** | ||
| * @param {number} tag | ||
| * @param {boolean[]} arr | ||
| */ | ||
| writePackedBoolean(tag, arr) { | ||
| if (arr.length) this.writeMessage(tag, writePackedBoolean, arr); | ||
| } | ||
| /** | ||
| * @param {number} tag | ||
| * @param {number[]} arr | ||
| */ | ||
| writePackedFloat(tag, arr) { | ||
| if (arr.length) this.writeMessage(tag, writePackedFloat, arr); | ||
| } | ||
| /** | ||
| * @param {number} tag | ||
| * @param {number[]} arr | ||
| */ | ||
| writePackedDouble(tag, arr) { | ||
| if (arr.length) this.writeMessage(tag, writePackedDouble, arr); | ||
| } | ||
| /** | ||
| * @param {number} tag | ||
| * @param {number[]} arr | ||
| */ | ||
| writePackedFixed32(tag, arr) { | ||
| if (arr.length) this.writeMessage(tag, writePackedFixed32, arr); | ||
| } | ||
| /** | ||
| * @param {number} tag | ||
| * @param {number[]} arr | ||
| */ | ||
| writePackedSFixed32(tag, arr) { | ||
| if (arr.length) this.writeMessage(tag, writePackedSFixed32, arr); | ||
| } | ||
| /** | ||
| * @param {number} tag | ||
| * @param {number[]} arr | ||
| */ | ||
| writePackedFixed64(tag, arr) { | ||
| if (arr.length) this.writeMessage(tag, writePackedFixed64, arr); | ||
| } | ||
| /** | ||
| * @param {number} tag | ||
| * @param {number[]} arr | ||
| */ | ||
| writePackedSFixed64(tag, arr) { | ||
| if (arr.length) this.writeMessage(tag, writePackedSFixed64, arr); | ||
| } | ||
| writeBytesField: function(tag, buffer) { | ||
| this.writeTag(tag, Pbf.Bytes); | ||
| /** | ||
| * @param {number} tag | ||
| * @param {Uint8Array} buffer | ||
| */ | ||
| writeBytesField(tag, buffer) { | ||
| this.writeTag(tag, PBF_BYTES); | ||
| this.writeBytes(buffer); | ||
| }, | ||
| writeFixed32Field: function(tag, val) { | ||
| this.writeTag(tag, Pbf.Fixed32); | ||
| } | ||
| /** | ||
| * @param {number} tag | ||
| * @param {number} val | ||
| */ | ||
| writeFixed32Field(tag, val) { | ||
| this.writeTag(tag, PBF_FIXED32); | ||
| this.writeFixed32(val); | ||
| }, | ||
| writeSFixed32Field: function(tag, val) { | ||
| this.writeTag(tag, Pbf.Fixed32); | ||
| } | ||
| /** | ||
| * @param {number} tag | ||
| * @param {number} val | ||
| */ | ||
| writeSFixed32Field(tag, val) { | ||
| this.writeTag(tag, PBF_FIXED32); | ||
| this.writeSFixed32(val); | ||
| }, | ||
| writeFixed64Field: function(tag, val) { | ||
| this.writeTag(tag, Pbf.Fixed64); | ||
| } | ||
| /** | ||
| * @param {number} tag | ||
| * @param {number} val | ||
| */ | ||
| writeFixed64Field(tag, val) { | ||
| this.writeTag(tag, PBF_FIXED64); | ||
| this.writeFixed64(val); | ||
| }, | ||
| writeSFixed64Field: function(tag, val) { | ||
| this.writeTag(tag, Pbf.Fixed64); | ||
| } | ||
| /** | ||
| * @param {number} tag | ||
| * @param {number} val | ||
| */ | ||
| writeSFixed64Field(tag, val) { | ||
| this.writeTag(tag, PBF_FIXED64); | ||
| this.writeSFixed64(val); | ||
| }, | ||
| writeVarintField: function(tag, val) { | ||
| this.writeTag(tag, Pbf.Varint); | ||
| } | ||
| /** | ||
| * @param {number} tag | ||
| * @param {number} val | ||
| */ | ||
| writeVarintField(tag, val) { | ||
| this.writeTag(tag, PBF_VARINT); | ||
| this.writeVarint(val); | ||
| }, | ||
| writeSVarintField: function(tag, val) { | ||
| this.writeTag(tag, Pbf.Varint); | ||
| } | ||
| /** | ||
| * @param {number} tag | ||
| * @param {number} val | ||
| */ | ||
| writeSVarintField(tag, val) { | ||
| this.writeTag(tag, PBF_VARINT); | ||
| this.writeSVarint(val); | ||
| }, | ||
| writeStringField: function(tag, str) { | ||
| this.writeTag(tag, Pbf.Bytes); | ||
| } | ||
| /** | ||
| * @param {number} tag | ||
| * @param {string} str | ||
| */ | ||
| writeStringField(tag, str) { | ||
| this.writeTag(tag, PBF_BYTES); | ||
| this.writeString(str); | ||
| }, | ||
| writeFloatField: function(tag, val) { | ||
| this.writeTag(tag, Pbf.Fixed32); | ||
| } | ||
| /** | ||
| * @param {number} tag | ||
| * @param {number} val | ||
| */ | ||
| writeFloatField(tag, val) { | ||
| this.writeTag(tag, PBF_FIXED32); | ||
| this.writeFloat(val); | ||
| }, | ||
| writeDoubleField: function(tag, val) { | ||
| this.writeTag(tag, Pbf.Fixed64); | ||
| } | ||
| /** | ||
| * @param {number} tag | ||
| * @param {number} val | ||
| */ | ||
| writeDoubleField(tag, val) { | ||
| this.writeTag(tag, PBF_FIXED64); | ||
| this.writeDouble(val); | ||
| }, | ||
| writeBooleanField: function(tag, val) { | ||
| this.writeVarintField(tag, Boolean(val)); | ||
| } | ||
| /** | ||
| * @param {number} tag | ||
| * @param {boolean} val | ||
| */ | ||
| writeBooleanField(tag, val) { | ||
| this.writeVarintField(tag, +val); | ||
| } | ||
| }; | ||
| /** | ||
| * @param {number} l | ||
| * @param {boolean | undefined} s | ||
| * @param {Pbf} p | ||
| */ | ||
| function readVarintRemainder(l, s, p) { | ||
| var buf = p.buf, | ||
| h, b; | ||
| const buf = p.buf; | ||
| let h, b; | ||
@@ -425,17 +560,17 @@ b = buf[p.pos++]; h = (b & 0x70) >> 4; if (b < 0x80) return toNum(l, h, s); | ||
| function readPackedEnd(pbf) { | ||
| return pbf.type === Pbf.Bytes ? | ||
| pbf.readVarint() + pbf.pos : pbf.pos + 1; | ||
| } | ||
| /** | ||
| * @param {number} low | ||
| * @param {number} high | ||
| * @param {boolean} [isSigned] | ||
| */ | ||
| function toNum(low, high, isSigned) { | ||
| if (isSigned) { | ||
| return high * 0x100000000 + (low >>> 0); | ||
| } | ||
| return ((high >>> 0) * 0x100000000) + (low >>> 0); | ||
| return isSigned ? high * 0x100000000 + (low >>> 0) : ((high >>> 0) * 0x100000000) + (low >>> 0); | ||
| } | ||
| /** | ||
| * @param {number} val | ||
| * @param {Pbf} pbf | ||
| */ | ||
| function writeBigVarint(val, pbf) { | ||
| var low, high; | ||
| let low, high; | ||
@@ -467,2 +602,7 @@ if (val >= 0) { | ||
| /** | ||
| * @param {number} high | ||
| * @param {number} low | ||
| * @param {Pbf} pbf | ||
| */ | ||
| function writeBigVarintLow(low, high, pbf) { | ||
@@ -476,4 +616,8 @@ pbf.buf[pbf.pos++] = low & 0x7f | 0x80; low >>>= 7; | ||
| /** | ||
| * @param {number} high | ||
| * @param {Pbf} pbf | ||
| */ | ||
| function writeBigVarintHigh(high, pbf) { | ||
| var lsb = (high & 0x07) << 4; | ||
| const lsb = (high & 0x07) << 4; | ||
@@ -488,4 +632,9 @@ pbf.buf[pbf.pos++] |= lsb | ((high >>>= 3) ? 0x80 : 0); if (!high) return; | ||
| /** | ||
| * @param {number} startPos | ||
| * @param {number} len | ||
| * @param {Pbf} pbf | ||
| */ | ||
| function makeRoomForExtraLength(startPos, len, pbf) { | ||
| var extraLen = | ||
| const extraLen = | ||
| len <= 0x3fff ? 1 : | ||
@@ -497,46 +646,84 @@ len <= 0x1fffff ? 2 : | ||
| pbf.realloc(extraLen); | ||
| for (var i = pbf.pos - 1; i >= startPos; i--) pbf.buf[i + extraLen] = pbf.buf[i]; | ||
| for (let i = pbf.pos - 1; i >= startPos; i--) pbf.buf[i + extraLen] = pbf.buf[i]; | ||
| } | ||
| function writePackedVarint(arr, pbf) { for (var i = 0; i < arr.length; i++) pbf.writeVarint(arr[i]); } | ||
| function writePackedSVarint(arr, pbf) { for (var i = 0; i < arr.length; i++) pbf.writeSVarint(arr[i]); } | ||
| function writePackedFloat(arr, pbf) { for (var i = 0; i < arr.length; i++) pbf.writeFloat(arr[i]); } | ||
| function writePackedDouble(arr, pbf) { for (var i = 0; i < arr.length; i++) pbf.writeDouble(arr[i]); } | ||
| function writePackedBoolean(arr, pbf) { for (var i = 0; i < arr.length; i++) pbf.writeBoolean(arr[i]); } | ||
| function writePackedFixed32(arr, pbf) { for (var i = 0; i < arr.length; i++) pbf.writeFixed32(arr[i]); } | ||
| function writePackedSFixed32(arr, pbf) { for (var i = 0; i < arr.length; i++) pbf.writeSFixed32(arr[i]); } | ||
| function writePackedFixed64(arr, pbf) { for (var i = 0; i < arr.length; i++) pbf.writeFixed64(arr[i]); } | ||
| function writePackedSFixed64(arr, pbf) { for (var i = 0; i < arr.length; i++) pbf.writeSFixed64(arr[i]); } | ||
| // Buffer code below from https://github.com/feross/buffer, MIT-licensed | ||
| function readUInt32(buf, pos) { | ||
| return ((buf[pos]) | | ||
| (buf[pos + 1] << 8) | | ||
| (buf[pos + 2] << 16)) + | ||
| (buf[pos + 3] * 0x1000000); | ||
| /** | ||
| * @param {number[]} arr | ||
| * @param {Pbf} pbf | ||
| */ | ||
| function writePackedVarint(arr, pbf) { | ||
| for (let i = 0; i < arr.length; i++) pbf.writeVarint(arr[i]); | ||
| } | ||
| function writeInt32(buf, val, pos) { | ||
| buf[pos] = val; | ||
| buf[pos + 1] = (val >>> 8); | ||
| buf[pos + 2] = (val >>> 16); | ||
| buf[pos + 3] = (val >>> 24); | ||
| /** | ||
| * @param {number[]} arr | ||
| * @param {Pbf} pbf | ||
| */ | ||
| function writePackedSVarint(arr, pbf) { | ||
| for (let i = 0; i < arr.length; i++) pbf.writeSVarint(arr[i]); | ||
| } | ||
| function readInt32(buf, pos) { | ||
| return ((buf[pos]) | | ||
| (buf[pos + 1] << 8) | | ||
| (buf[pos + 2] << 16)) + | ||
| (buf[pos + 3] << 24); | ||
| /** | ||
| * @param {number[]} arr | ||
| * @param {Pbf} pbf | ||
| */ | ||
| function writePackedFloat(arr, pbf) { | ||
| for (let i = 0; i < arr.length; i++) pbf.writeFloat(arr[i]); | ||
| } | ||
| /** | ||
| * @param {number[]} arr | ||
| * @param {Pbf} pbf | ||
| */ | ||
| function writePackedDouble(arr, pbf) { | ||
| for (let i = 0; i < arr.length; i++) pbf.writeDouble(arr[i]); | ||
| } | ||
| /** | ||
| * @param {boolean[]} arr | ||
| * @param {Pbf} pbf | ||
| */ | ||
| function writePackedBoolean(arr, pbf) { | ||
| for (let i = 0; i < arr.length; i++) pbf.writeBoolean(arr[i]); | ||
| } | ||
| /** | ||
| * @param {number[]} arr | ||
| * @param {Pbf} pbf | ||
| */ | ||
| function writePackedFixed32(arr, pbf) { | ||
| for (let i = 0; i < arr.length; i++) pbf.writeFixed32(arr[i]); | ||
| } | ||
| /** | ||
| * @param {number[]} arr | ||
| * @param {Pbf} pbf | ||
| */ | ||
| function writePackedSFixed32(arr, pbf) { | ||
| for (let i = 0; i < arr.length; i++) pbf.writeSFixed32(arr[i]); | ||
| } | ||
| /** | ||
| * @param {number[]} arr | ||
| * @param {Pbf} pbf | ||
| */ | ||
| function writePackedFixed64(arr, pbf) { | ||
| for (let i = 0; i < arr.length; i++) pbf.writeFixed64(arr[i]); | ||
| } | ||
| /** | ||
| * @param {number[]} arr | ||
| * @param {Pbf} pbf | ||
| */ | ||
| function writePackedSFixed64(arr, pbf) { | ||
| for (let i = 0; i < arr.length; i++) pbf.writeSFixed64(arr[i]); | ||
| } | ||
| // Buffer code below from https://github.com/feross/buffer, MIT-licensed | ||
| /** | ||
| * @param {Uint8Array} buf | ||
| * @param {number} pos | ||
| * @param {number} end | ||
| */ | ||
| function readUtf8(buf, pos, end) { | ||
| var str = ''; | ||
| var i = pos; | ||
| let str = ''; | ||
| let i = pos; | ||
| while (i < end) { | ||
| var b0 = buf[i]; | ||
| var c = null; // codepoint | ||
| var bytesPerSequence = | ||
| const b0 = buf[i]; | ||
| let c = null; // codepoint | ||
| let bytesPerSequence = | ||
| b0 > 0xEF ? 4 : | ||
@@ -548,3 +735,3 @@ b0 > 0xDF ? 3 : | ||
| var b1, b2, b3; | ||
| let b1, b2, b3; | ||
@@ -601,8 +788,9 @@ if (bytesPerSequence === 1) { | ||
| function readUtf8TextDecoder(buf, pos, end) { | ||
| return utf8TextDecoder.decode(buf.subarray(pos, end)); | ||
| } | ||
| /** | ||
| * @param {Uint8Array} buf | ||
| * @param {string} str | ||
| * @param {number} pos | ||
| */ | ||
| function writeUtf8(buf, str, pos) { | ||
| for (var i = 0, c, lead; i < str.length; i++) { | ||
| for (let i = 0, c, lead; i < str.length; i++) { | ||
| c = str.charCodeAt(i); // code point | ||
@@ -609,0 +797,0 @@ |
| { | ||
| "name": "pbf", | ||
| "version": "3.3.0", | ||
| "version": "4.0.0", | ||
| "description": "a low-level, lightweight protocol buffers implementation in JavaScript", | ||
| "main": "index.js", | ||
| "unpkg": "dist/pbf.js", | ||
| "jsdelivr": "dist/pbf.js", | ||
| "type": "module", | ||
| "exports": { | ||
| ".": "./index.js", | ||
| "./compile": "./compile.js" | ||
| }, | ||
| "scripts": { | ||
| "bench": "node bench/bench.js", | ||
| "pretest": "eslint index.js compile.js test/*.js bench/bench-tiles.js bin/pbf", | ||
| "test": "node --test", | ||
| "pretest": "eslint *.js compile.js test/*.js test/fixtures/*.js bin/pbf", | ||
| "test": "tsc && node --test", | ||
| "cov": "node --test --experimental-test-covetage", | ||
| "build-min": "mkdirp dist && browserify index.js -s Pbf | uglifyjs -c -m > dist/pbf.js", | ||
| "build-dev": "mkdirp dist && browserify index.js -d -s Pbf > dist/pbf-dev.js", | ||
| "prepublishOnly": "npm run build-dev && npm run build-min" | ||
| "build": "rollup -c", | ||
| "prepublishOnly": "npm run test && npm run build" | ||
| }, | ||
@@ -20,4 +22,6 @@ "files": [ | ||
| "dist", | ||
| "compile.js" | ||
| "compile.js", | ||
| "index.d.ts" | ||
| ], | ||
| "types": "index.d.ts", | ||
| "bin": { | ||
@@ -48,36 +52,15 @@ "pbf": "bin/pbf" | ||
| "dependencies": { | ||
| "ieee754": "^1.1.12", | ||
| "resolve-protobuf-schema": "^2.1.0" | ||
| }, | ||
| "devDependencies": { | ||
| "@rollup/plugin-terser": "^0.4.4", | ||
| "benchmark": "^2.1.4", | ||
| "browserify": "^17.0.0", | ||
| "eslint": "^8.57.0", | ||
| "eslint-config-mourner": "^2.0.3", | ||
| "mkdirp": "^3.0.1", | ||
| "eslint": "^9.6.0", | ||
| "eslint-config-mourner": "^4.0.1", | ||
| "protobufjs": "^7.3.2", | ||
| "protocol-buffers": "^5.0.0", | ||
| "rollup": "^4.18.0", | ||
| "tile-stats-runner": "^1.0.0", | ||
| "uglify-js": "^3.18.0" | ||
| }, | ||
| "eslintConfig": { | ||
| "extends": "mourner", | ||
| "rules": { | ||
| "space-before-function-paren": [ | ||
| 2, | ||
| "never" | ||
| ], | ||
| "key-spacing": 0, | ||
| "no-empty": 0, | ||
| "global-require": 0, | ||
| "no-cond-assign": 0, | ||
| "indent": [ | ||
| 2, | ||
| 4, | ||
| { | ||
| "flatTernaryExpressions": true | ||
| } | ||
| ] | ||
| } | ||
| "typescript": "^5.5.3" | ||
| } | ||
| } |
240
README.md
@@ -36,36 +36,24 @@ # pbf | ||
| ```js | ||
| var Pbf = require('pbf'); | ||
| var Example = require('./example.js').Example; | ||
| import Pbf from 'pbf'; | ||
| import {readExample, writeExample} from './example.js'; | ||
| // read | ||
| var pbf = new Pbf(buffer); | ||
| var obj = Example.read(pbf); | ||
| var obj = readExample(new Pbf(buffer)); | ||
| // write | ||
| var pbf = new Pbf(); | ||
| Example.write(obj, pbf); | ||
| var buffer = pbf.finish(); | ||
| const pbf = new Pbf(); | ||
| writeExample(obj, pbf); | ||
| const buffer = pbf.finish(); | ||
| ``` | ||
| Alternatively, you can compile a module directly in the code: | ||
| Alternatively, you can compile a protobuf schema file directly in the code: | ||
| ```js | ||
| var compile = require('pbf/compile'); | ||
| var schema = require('protocol-buffers-schema'); | ||
| import {compile} from 'pbf/compile'; | ||
| import schema from 'protocol-buffers-schema'; | ||
| var proto = schema.parse(fs.readFileSync('example.proto')); | ||
| var Test = compile(proto).Test; | ||
| const proto = schema.parse(fs.readFileSync('example.proto')); | ||
| const {readExample, writeExample} = compile(proto); | ||
| ``` | ||
| If you use `webpack` as your module bundler, you can use [pbf-loader](https://github.com/trivago/pbf-loader) | ||
| to load .proto files directly. It returns a compiled module ready to be used. | ||
| Given you already configured your `webpack.config.js`, the code above would look like: | ||
| ```js | ||
| var Pbf = require('pbf'); | ||
| var proto = require('./example.proto'); | ||
| var Test = proto.Test; | ||
| ``` | ||
| #### Custom Reading | ||
@@ -107,18 +95,22 @@ | ||
| Node and Browserify: | ||
| Install using NPM with `npm install pbf`, then import as a module: | ||
| ```bash | ||
| npm install pbf | ||
| ```js | ||
| import Pbf from 'pbf'; | ||
| ``` | ||
| Making a browser build: | ||
| Or use as a module directly in the browser with [jsDelivr](https://www.jsdelivr.com/esm): | ||
| ```bash | ||
| npm install | ||
| npm run build-dev # dist/pbf-dev.js (development build) | ||
| npm run build-min # dist/pbf.js (minified production build) | ||
| ```html | ||
| <script type="module"> | ||
| import Pbf from 'https://cdn.jsdelivr.net/npm/pbf/+esm'; | ||
| </script> | ||
| ``` | ||
| CDN link: https://unpkg.com/pbf@3.0.5/dist/pbf.js | ||
| Alternatively, there's a browser bundle with a `Pbf` global variable: | ||
| ```html | ||
| <script src="https://cdn.jsdelivr.net/npm/pbf"></script> | ||
| ``` | ||
| ## API | ||
@@ -130,6 +122,6 @@ | ||
| // parse a pbf file from disk in Node | ||
| var pbf = new Pbf(fs.readFileSync('data.pbf')); | ||
| const pbf = new Pbf(fs.readFileSync('data.pbf')); | ||
| // parse a pbf file in a browser after an ajax request with responseType="arraybuffer" | ||
| var pbf = new Pbf(new Uint8Array(xhr.response)); | ||
| const pbf = new Pbf(new Uint8Array(xhr.response)); | ||
| ``` | ||
@@ -149,3 +141,3 @@ | ||
| ```js | ||
| pbf.readFields(function (tag) { | ||
| pbf.readFields((tag) => { | ||
| if (tag === 1) pbf.readVarint(); | ||
@@ -161,5 +153,5 @@ else if (tag === 2) pbf.readString(); | ||
| ```js | ||
| var result = pbf.readFields(callback, {}) | ||
| const result = pbf.readFields(readField, {}) | ||
| function callback(tag, result, pbf) { | ||
| function readField(tag, result, pbf) { | ||
| if (tag === 1) result.id = pbf.readVarint(); | ||
@@ -174,5 +166,5 @@ } | ||
| ```js | ||
| var value = pbf.readVarint(); | ||
| var str = pbf.readString(); | ||
| var numbers = pbf.readPackedVarint(); | ||
| const value = pbf.readVarint(); | ||
| const str = pbf.readString(); | ||
| const numbers = pbf.readPackedVarint(); | ||
| ``` | ||
@@ -184,4 +176,4 @@ | ||
| ```js | ||
| var fooPos = -1; | ||
| pbf.readFields(function (tag) { | ||
| const fooPos = -1; | ||
| pbf.readFields((tag) => { | ||
| if (tag === 1) fooPos = pbf.pos; | ||
@@ -287,3 +279,2 @@ }); | ||
| * `finish()` - make the current buffer ready for reading and return the data as a buffer slice | ||
| * `destroy()` - dispose the buffer | ||
@@ -298,165 +289,14 @@ For an example of a real-world usage of the library, see [vector-tile-js](https://github.com/mapbox/vector-tile-js). | ||
| ```bash | ||
| $ pbf <proto_path> [--no-write] [--no-read] [--browser] | ||
| $ pbf <proto_path> [--no-write] [--no-read] [--legacy] | ||
| ``` | ||
| The `--no-write` and `--no-read` switches remove corresponding code in the output. | ||
| The `--browser` switch makes the module work in browsers instead of Node. | ||
| The `--legacy` switch makes it generate a CommonJS module instead of ESM. | ||
| The resulting module exports each message by name with the following methods: | ||
| `Pbf` will generate `read<Identifier>` and `write<Identifier>` functions for every message in the schema. For nested messages, their names will be concatenated — e.g. `Message` inside `Test` will produce `readTestMessage` and `writeTestMessage` functions. | ||
| * `read(pbf)` - decodes an object from the given `Pbf` instance | ||
| * `write(obj, pbf)` - encodes an object into the given `Pbf` instance (usually empty) | ||
| The resulting code is clean and simple, so feel free to customize it. | ||
| * `read(pbf)` - decodes an object from the given `Pbf` instance. | ||
| * `write(obj, pbf)` - encodes an object into the given `Pbf` instance (usually empty). | ||
| ## Changelog | ||
| #### 3.2.1 (Oct 11, 2019) | ||
| - Significantly improved performance when decoding large strings in the browser. | ||
| #### 3.2.0 (Mar 11, 2019) | ||
| - Improved decoding to be able to parse repeated fields even if they were specified as packed, and vise versa. | ||
| - Improved packed encoding to skip empty arrays (previously, it would write a tag). | ||
| - Fixed an off-by-one data corruption bug when writing a message larger than 0x10000000 bytes. | ||
| #### 3.1.0 (Sep 27, 2017) | ||
| - Added support for Protocol Buffer 3 [maps](https://developers.google.com/protocol-buffers/docs/proto3#maps) to proto compiler. | ||
| #### 3.0.5 (Nov 30, 2016) | ||
| - Fixed an error appearing in some versions of IE11 and old Android browsers. | ||
| #### 3.0.4 (Nov 14, 2016) | ||
| - Fixed compiling repeated packed enum fields. | ||
| #### 3.0.3 (Nov 14, 2016) | ||
| - Fixed a regression that broke compiling repeated enum fields with defaults. | ||
| #### 3.0.2 (Sep 30, 2016) | ||
| - Fixed a regression that broke decoding of packed fields with a tag that didn't fit into one byte. | ||
| #### 3.0.1 (Sep 20, 2016) | ||
| - Fixed a regression that broke encoding of long strings. | ||
| #### 3.0.0 (Aug 30, 2016) | ||
| This release include tons of compatibility/robustness fixes, and a more reliable Node implementation. Decoding performance is expected to get up to ~15% slower than v2.0 in Node (browsers are unaffected), but encoding got faster by ~15% in return. | ||
| ##### Encoder/decoder | ||
| - **Breaking**: changed Node implementation to use `Uint8Array` instead of `Buffer` internally (and produce corresponding result on `finish()`), making it fully match the browser implementation for consistency and simplicity. | ||
| - Fixed `writeVarint` to write `0` when given `NaN` or other non-number to avoid producing a broken Protobuf message. | ||
| - Changed `readPacked*` methods signature to accept an optional `arr` argument to append the results to (to support messages with repeated fields that mix packed/non-packed encoding). | ||
| - Added an optional `isSigned` argument to `readVarint` that enables proper reading of negative varints. | ||
| - Deprecated `readVarint64()` (it still works, but it's recommended to be changed to `readVarint(true)`). | ||
| - Faster string encoding. | ||
| ##### Proto compiler | ||
| - **Breaking:** Full support for defaults field values (both implicit and explicit); they're now included in the decoded JSON objects. | ||
| - Fixed reading of repeated fields with mixed packed/non-packed encoding for compatibility. | ||
| - Fixed proto3 compiler to use packed by default for repeated scalar fields. | ||
| - Fixed reading of negative varint types. | ||
| - Fixed packed fields to decode into `[]` if they're not present. | ||
| - Fixed nested message references handling. | ||
| - Fixed `packed=false` being interpreted as packed. | ||
| - Added a comment to generated code with pbf version number. | ||
| #### 2.0.1 (May 28, 2016) | ||
| - Fixed a regression with `writeVarint` that affected certain numbers. | ||
| #### 2.0.0 (May 28, 2016) | ||
| - Significantly improved the proto compiler, which now produces a much safer reading/writing code. | ||
| - Added the ability to compile a read/write module from a protobuf schema directly in the code. | ||
| - Proto compiler: fixed name resolutions and collisions in schemas with nested messages. | ||
| - Proto compiler: fixed broken top-level enums. | ||
| #### 1.3.7 (May 28, 2016) | ||
| - Fixed a regression with `writeVarint` that affected certain numbers. | ||
| #### 1.3.6 (May 27, 2016) | ||
| - Improved read and write performance (both ~15% faster). | ||
| - Improved generated code for default values. | ||
| #### 1.3.5 (Oct 5, 2015) | ||
| - Added support for `syntax` keyword proto files (by updating `resolve-protobuf-schema` dependency). | ||
| #### 1.3.4 (Jul 31, 2015) | ||
| - Added `writeRawMessage` method for writing a message without a tag, useful for creating pbfs with multiple top-level messages. | ||
| #### 1.3.2 (Mar 5, 2015) | ||
| - Added `readVarint64` method for proper decoding of negative `int64`-encoded values. | ||
| #### 1.3.1 (Feb 20, 2015) | ||
| - Fixed pbf proto compile tool generating broken writing code. | ||
| #### 1.3.0 (Feb 5, 2015) | ||
| - Added `pbf` binary that compiles `.proto` files into `Pbf`-based JavaScript modules. | ||
| #### 1.2.0 (Jan 5, 2015) | ||
| ##### Breaking API changes | ||
| - Changed `writeMessage` signature to `(tag, fn, obj)` (see example in the docs) | ||
| for a huge encoding performance improvement. | ||
| - Replaced `readPacked` and `writePacked` methods that accept type as a string | ||
| with `readPackedVarint`, etc. for each type (better performance and simpler API). | ||
| ##### Improvements | ||
| - 5x faster encoding in Node (vector tile benchmark). | ||
| - 40x faster encoding and 3x faster decoding in the browser (vector tile benchmark). | ||
| #### 1.1.4 (Jan 2, 2015) | ||
| - Significantly improved `readPacked` and `writePacked` performance (the tile reading benchmark is now 70% faster). | ||
| #### 1.1.3 (Dec 26, 2014) | ||
| Brings tons of improvements and fixes over the previous version (`0.0.2`). | ||
| Basically makes the library complete. | ||
| ##### Improvements | ||
| - Improved performance of both reading and writing. | ||
| - Made the browser build 3 times smaller. | ||
| - Added convenience `readFields` and `readMessage` methods for a much easier reading API. | ||
| - Added reading methods: `readFloat`, `readBoolean`, `readSFixed32`, `readSFixed64`. | ||
| - Added writing methods: `writeUInt64`, `writeSFixed32`, `writeSFixed64`. | ||
| - Improved `readDouble` and `readString` to use native Buffer methods under Node. | ||
| - Improved `readString` and `writeString` to use HTML5 `TextEncoder` and `TextDecoder` where available. | ||
| - Made `Pbf` `buffer` argument optional. | ||
| - Added extensive docs and examples in the readme. | ||
| - Added an extensive test suite that brings test coverage up to 100%. | ||
| ##### Breaking API changes | ||
| - Renamed `readBuffer`/`writeBuffer` to `readBytes`/`writeBytes`. | ||
| - Renamed `readUInt32`/`writeUInt32` to `readFixed32`/`writeFixed32`, etc. | ||
| - Renamed `writeTaggedVarint` to `writeVarintField`, etc. | ||
| - Changed `writePacked` signature from `(type, tag, items)` to `(tag, type, items)`. | ||
| ##### Bugfixes | ||
| - Fixed `readVarint` to handle varints bigger than 6 bytes. | ||
| - Fixed `readSVarint` to handle number bigger than `2^30`. | ||
| - Fixed `writeVarint` failing on some integers. | ||
| - Fixed `writeVarint` not throwing an error on numbers that are too big. | ||
| - Fixed `readUInt64` always failing. | ||
| - Fixed writing to an empty buffer always failing. | ||
| The resulting code is clean and simple, so it's meant to be customized. |
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
New alerts
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
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
New author
Supply chain riskA new npm collaborator published a version of the package for the first time. New collaborators are usually benign additions to a project, but do indicate a change to the security surface area of a package.
Found 1 instance in 1 package
Uses eval
Supply chain riskPackage uses dynamic code execution (e.g., eval()), which is a dangerous practice. This can prevent the code from running in certain environments and increases the risk that the code may contain exploits or malicious behavior.
Found 1 instance in 1 package
Filesystem access
Supply chain riskAccesses the file system, and could potentially read sensitive data.
Found 1 instance in 1 package
Fixed alerts
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
New author
Supply chain riskA new npm collaborator published a version of the package for the first time. New collaborators are usually benign additions to a project, but do indicate a change to the security surface area of a package.
Found 1 instance in 1 package
Uses eval
Supply chain riskPackage uses dynamic code execution (e.g., eval()), which is a dangerous practice. This can prevent the code from running in certain environments and increases the risk that the code may contain exploits or malicious behavior.
Found 1 instance in 1 package
Dynamic require
Supply chain riskDynamic require can indicate the package is performing dangerous or unsafe dynamic code execution.
Found 1 instance in 1 package
Minified code
QualityThis package contains minified code. This may be harmless in some cases where minified code is included in packaged libraries, however packages on npm should not minify code.
Found 1 instance in 1 package
Improved metrics
- Dependency count
- decreased by-50%
1
- Number of package files
- increased by12.5%
9
- Lines of code
- increased by20.6%
2084
- Number of low quality alerts
- decreased by-100%
0
- Number of low supply chain risk alerts
- decreased by-75%
1
- Is type module
Yes
Worsened metrics
- Total package byte prevSize
- decreased by-31.95%
85802
- Number of lines in readme file
- decreased by-35.24%
294
- Number of medium supply chain risk alerts
- increased by50%
3
Dependency changes
- Removedieee754@^1.1.12
- Removedieee754@1.2.1(transitive)