| // Protocol Buffers - Google's data interchange format |
| // Copyright 2008 Google Inc. All rights reserved. |
| // https://developers.google.com/protocol-buffers/ |
| // |
| // Redistribution and use in source and binary forms, with or without |
| // modification, are permitted provided that the following conditions are |
| // met: |
| // |
| // * Redistributions of source code must retain the above copyright |
| // notice, this list of conditions and the following disclaimer. |
| // * Redistributions in binary form must reproduce the above |
| // copyright notice, this list of conditions and the following disclaimer |
| // in the documentation and/or other materials provided with the |
| // distribution. |
| // * Neither the name of Google Inc. nor the names of its |
| // contributors may be used to endorse or promote products derived from |
| // this software without specific prior written permission. |
| // |
| // THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS |
| // "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT |
| // LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR |
| // A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT |
| // OWNER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, |
| // SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT |
| // LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, |
| // DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY |
| // THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT |
| // (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE |
| // OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE. |
| |
| /** |
| * @fileoverview This file contains utilities for converting binary, |
| * wire-format protocol buffers into Javascript data structures. |
| * |
| * jspb's BinaryReader class wraps the BinaryDecoder class to add methods |
| * that understand the protocol buffer syntax and can do the type checking and |
| * bookkeeping necessary to parse trees of nested messages. |
| * |
| * Major caveat - Users of this library _must_ keep their Javascript proto |
| * parsing code in sync with the original .proto file - presumably you'll be |
| * using the typed jspb code generator, but if you bypass that you'll need |
| * to keep things in sync by hand. |
| * |
| * @author aappleby@google.com (Austin Appleby) |
| */ |
| |
| goog.provide('jspb.BinaryReader'); |
| |
| goog.require('goog.asserts'); |
| goog.require('jspb.BinaryConstants'); |
| goog.require('jspb.BinaryDecoder'); |
| |
| |
| |
| /** |
| * BinaryReader implements the decoders for all the wire types specified in |
| * https://developers.google.com/protocol-buffers/docs/encoding. |
| * |
| * @param {jspb.ByteSource=} opt_bytes The bytes we're reading from. |
| * @param {number=} opt_start The optional offset to start reading at. |
| * @param {number=} opt_length The optional length of the block to read - |
| * we'll throw an assertion if we go off the end of the block. |
| * @constructor |
| * @struct |
| */ |
| jspb.BinaryReader = function(opt_bytes, opt_start, opt_length) { |
| /** |
| * Wire-format decoder. |
| * @private {!jspb.BinaryDecoder} |
| */ |
| this.decoder_ = jspb.BinaryDecoder.alloc(opt_bytes, opt_start, opt_length); |
| |
| /** |
| * Cursor immediately before the field tag. |
| * @private {number} |
| */ |
| this.fieldCursor_ = this.decoder_.getCursor(); |
| |
| /** |
| * Field number of the next field in the buffer, filled in by nextField(). |
| * @private {number} |
| */ |
| this.nextField_ = jspb.BinaryConstants.INVALID_FIELD_NUMBER; |
| |
| /** |
| * Wire type of the next proto field in the buffer, filled in by |
| * nextField(). |
| * @private {jspb.BinaryConstants.WireType} |
| */ |
| this.nextWireType_ = jspb.BinaryConstants.WireType.INVALID; |
| |
| /** |
| * Set to true if this reader encountered an error due to corrupt data. |
| * @private {boolean} |
| */ |
| this.error_ = false; |
| |
| /** |
| * User-defined reader callbacks. |
| * @private {Object<string, function(!jspb.BinaryReader):*>} |
| */ |
| this.readCallbacks_ = null; |
| }; |
| |
| |
| /** |
| * Global pool of BinaryReader instances. |
| * @private {!Array<!jspb.BinaryReader>} |
| */ |
| jspb.BinaryReader.instanceCache_ = []; |
| |
| |
| /** |
| * Pops an instance off the instance cache, or creates one if the cache is |
| * empty. |
| * @param {jspb.ByteSource=} opt_bytes The bytes we're reading from. |
| * @param {number=} opt_start The optional offset to start reading at. |
| * @param {number=} opt_length The optional length of the block to read - |
| * we'll throw an assertion if we go off the end of the block. |
| * @return {!jspb.BinaryReader} |
| */ |
| jspb.BinaryReader.alloc = |
| function(opt_bytes, opt_start, opt_length) { |
| if (jspb.BinaryReader.instanceCache_.length) { |
| var newReader = jspb.BinaryReader.instanceCache_.pop(); |
| if (opt_bytes) { |
| newReader.decoder_.setBlock(opt_bytes, opt_start, opt_length); |
| } |
| return newReader; |
| } else { |
| return new jspb.BinaryReader(opt_bytes, opt_start, opt_length); |
| } |
| }; |
| |
| |
| /** |
| * Alias for the above method. |
| * @param {jspb.ByteSource=} opt_bytes The bytes we're reading from. |
| * @param {number=} opt_start The optional offset to start reading at. |
| * @param {number=} opt_length The optional length of the block to read - |
| * we'll throw an assertion if we go off the end of the block. |
| * @return {!jspb.BinaryReader} |
| */ |
| jspb.BinaryReader.prototype.alloc = jspb.BinaryReader.alloc; |
| |
| |
| /** |
| * Puts this instance back in the instance cache. |
| */ |
| jspb.BinaryReader.prototype.free = function() { |
| this.decoder_.clear(); |
| this.nextField_ = jspb.BinaryConstants.INVALID_FIELD_NUMBER; |
| this.nextWireType_ = jspb.BinaryConstants.WireType.INVALID; |
| this.error_ = false; |
| this.readCallbacks_ = null; |
| |
| if (jspb.BinaryReader.instanceCache_.length < 100) { |
| jspb.BinaryReader.instanceCache_.push(this); |
| } |
| }; |
| |
| |
| /** |
| * Returns the cursor immediately before the current field's tag. |
| * @return {number} The internal read cursor. |
| */ |
| jspb.BinaryReader.prototype.getFieldCursor = function() { |
| return this.fieldCursor_; |
| }; |
| |
| |
| /** |
| * Returns the internal read cursor. |
| * @return {number} The internal read cursor. |
| */ |
| jspb.BinaryReader.prototype.getCursor = function() { |
| return this.decoder_.getCursor(); |
| }; |
| |
| |
| /** |
| * Returns the raw buffer. |
| * @return {?Uint8Array} The raw buffer. |
| */ |
| jspb.BinaryReader.prototype.getBuffer = function() { |
| return this.decoder_.getBuffer(); |
| }; |
| |
| |
| /** |
| * @return {number} The field number of the next field in the buffer, or |
| * INVALID_FIELD_NUMBER if there is no next field. |
| */ |
| jspb.BinaryReader.prototype.getFieldNumber = function() { |
| return this.nextField_; |
| }; |
| |
| |
| /** |
| * @return {jspb.BinaryConstants.WireType} The wire type of the next field |
| * in the stream, or WireType.INVALID if there is no next field. |
| */ |
| jspb.BinaryReader.prototype.getWireType = function() { |
| return this.nextWireType_; |
| }; |
| |
| |
| /** |
| * @return {boolean} Whether the current wire type is an end-group tag. Used as |
| * an exit condition in decoder loops in generated code. |
| */ |
| jspb.BinaryReader.prototype.isEndGroup = function() { |
| return this.nextWireType_ == jspb.BinaryConstants.WireType.END_GROUP; |
| }; |
| |
| |
| /** |
| * Returns true if this reader hit an error due to corrupt data. |
| * @return {boolean} |
| */ |
| jspb.BinaryReader.prototype.getError = function() { |
| return this.error_ || this.decoder_.getError(); |
| }; |
| |
| |
| /** |
| * Points this reader at a new block of bytes. |
| * @param {!Uint8Array} bytes The block of bytes we're reading from. |
| * @param {number} start The offset to start reading at. |
| * @param {number} length The length of the block to read. |
| */ |
| jspb.BinaryReader.prototype.setBlock = function(bytes, start, length) { |
| this.decoder_.setBlock(bytes, start, length); |
| this.nextField_ = jspb.BinaryConstants.INVALID_FIELD_NUMBER; |
| this.nextWireType_ = jspb.BinaryConstants.WireType.INVALID; |
| }; |
| |
| |
| /** |
| * Rewinds the stream cursor to the beginning of the buffer and resets all |
| * internal state. |
| */ |
| jspb.BinaryReader.prototype.reset = function() { |
| this.decoder_.reset(); |
| this.nextField_ = jspb.BinaryConstants.INVALID_FIELD_NUMBER; |
| this.nextWireType_ = jspb.BinaryConstants.WireType.INVALID; |
| }; |
| |
| |
| /** |
| * Advances the stream cursor by the given number of bytes. |
| * @param {number} count The number of bytes to advance by. |
| */ |
| jspb.BinaryReader.prototype.advance = function(count) { |
| this.decoder_.advance(count); |
| }; |
| |
| |
| /** |
| * Reads the next field header in the stream if there is one, returns true if |
| * we saw a valid field header or false if we've read the whole stream. |
| * Throws an error if we encountered a deprecated START_GROUP/END_GROUP field. |
| * @return {boolean} True if the stream contains more fields. |
| */ |
| jspb.BinaryReader.prototype.nextField = function() { |
| // If we're at the end of the block, there are no more fields. |
| if (this.decoder_.atEnd()) { |
| return false; |
| } |
| |
| // If we hit an error decoding the previous field, stop now before we |
| // try to decode anything else |
| if (this.getError()) { |
| goog.asserts.fail('Decoder hit an error'); |
| return false; |
| } |
| |
| // Otherwise just read the header of the next field. |
| this.fieldCursor_ = this.decoder_.getCursor(); |
| var header = this.decoder_.readUnsignedVarint32(); |
| |
| var nextField = header >>> 3; |
| var nextWireType = /** @type {jspb.BinaryConstants.WireType} */ |
| (header & 0x7); |
| |
| // If the wire type isn't one of the valid ones, something's broken. |
| if (nextWireType != jspb.BinaryConstants.WireType.VARINT && |
| nextWireType != jspb.BinaryConstants.WireType.FIXED32 && |
| nextWireType != jspb.BinaryConstants.WireType.FIXED64 && |
| nextWireType != jspb.BinaryConstants.WireType.DELIMITED && |
| nextWireType != jspb.BinaryConstants.WireType.START_GROUP && |
| nextWireType != jspb.BinaryConstants.WireType.END_GROUP) { |
| goog.asserts.fail('Invalid wire type'); |
| this.error_ = true; |
| return false; |
| } |
| |
| this.nextField_ = nextField; |
| this.nextWireType_ = nextWireType; |
| |
| return true; |
| }; |
| |
| |
| /** |
| * Winds the reader back to just before this field's header. |
| */ |
| jspb.BinaryReader.prototype.unskipHeader = function() { |
| this.decoder_.unskipVarint((this.nextField_ << 3) | this.nextWireType_); |
| }; |
| |
| |
| /** |
| * Skips all contiguous fields whose header matches the one we just read. |
| */ |
| jspb.BinaryReader.prototype.skipMatchingFields = function() { |
| var field = this.nextField_; |
| this.unskipHeader(); |
| |
| while (this.nextField() && (this.getFieldNumber() == field)) { |
| this.skipField(); |
| } |
| |
| if (!this.decoder_.atEnd()) { |
| this.unskipHeader(); |
| } |
| }; |
| |
| |
| /** |
| * Skips over the next varint field in the binary stream. |
| */ |
| jspb.BinaryReader.prototype.skipVarintField = function() { |
| if (this.nextWireType_ != jspb.BinaryConstants.WireType.VARINT) { |
| goog.asserts.fail('Invalid wire type for skipVarintField'); |
| this.skipField(); |
| return; |
| } |
| |
| this.decoder_.skipVarint(); |
| }; |
| |
| |
| /** |
| * Skips over the next delimited field in the binary stream. |
| */ |
| jspb.BinaryReader.prototype.skipDelimitedField = function() { |
| if (this.nextWireType_ != jspb.BinaryConstants.WireType.DELIMITED) { |
| goog.asserts.fail('Invalid wire type for skipDelimitedField'); |
| this.skipField(); |
| return; |
| } |
| |
| var length = this.decoder_.readUnsignedVarint32(); |
| this.decoder_.advance(length); |
| }; |
| |
| |
| /** |
| * Skips over the next fixed32 field in the binary stream. |
| */ |
| jspb.BinaryReader.prototype.skipFixed32Field = function() { |
| if (this.nextWireType_ != jspb.BinaryConstants.WireType.FIXED32) { |
| goog.asserts.fail('Invalid wire type for skipFixed32Field'); |
| this.skipField(); |
| return; |
| } |
| |
| this.decoder_.advance(4); |
| }; |
| |
| |
| /** |
| * Skips over the next fixed64 field in the binary stream. |
| */ |
| jspb.BinaryReader.prototype.skipFixed64Field = function() { |
| if (this.nextWireType_ != jspb.BinaryConstants.WireType.FIXED64) { |
| goog.asserts.fail('Invalid wire type for skipFixed64Field'); |
| this.skipField(); |
| return; |
| } |
| |
| this.decoder_.advance(8); |
| }; |
| |
| |
| /** |
| * Skips over the next group field in the binary stream. |
| */ |
| jspb.BinaryReader.prototype.skipGroup = function() { |
| // Keep a stack of start-group tags that must be matched by end-group tags. |
| var nestedGroups = [this.nextField_]; |
| do { |
| if (!this.nextField()) { |
| goog.asserts.fail('Unmatched start-group tag: stream EOF'); |
| this.error_ = true; |
| return; |
| } |
| if (this.nextWireType_ == |
| jspb.BinaryConstants.WireType.START_GROUP) { |
| // Nested group start. |
| nestedGroups.push(this.nextField_); |
| } else if (this.nextWireType_ == |
| jspb.BinaryConstants.WireType.END_GROUP) { |
| // Group end: check that it matches top-of-stack. |
| if (this.nextField_ != nestedGroups.pop()) { |
| goog.asserts.fail('Unmatched end-group tag'); |
| this.error_ = true; |
| return; |
| } |
| } |
| } while (nestedGroups.length > 0); |
| }; |
| |
| |
| /** |
| * Skips over the next field in the binary stream - this is useful if we're |
| * decoding a message that contain unknown fields. |
| */ |
| jspb.BinaryReader.prototype.skipField = function() { |
| switch (this.nextWireType_) { |
| case jspb.BinaryConstants.WireType.VARINT: |
| this.skipVarintField(); |
| break; |
| case jspb.BinaryConstants.WireType.FIXED64: |
| this.skipFixed64Field(); |
| break; |
| case jspb.BinaryConstants.WireType.DELIMITED: |
| this.skipDelimitedField(); |
| break; |
| case jspb.BinaryConstants.WireType.FIXED32: |
| this.skipFixed32Field(); |
| break; |
| case jspb.BinaryConstants.WireType.START_GROUP: |
| this.skipGroup(); |
| break; |
| default: |
| goog.asserts.fail('Invalid wire encoding for field.'); |
| } |
| }; |
| |
| |
| /** |
| * Registers a user-defined read callback. |
| * @param {string} callbackName |
| * @param {function(!jspb.BinaryReader):*} callback |
| */ |
| jspb.BinaryReader.prototype.registerReadCallback = |
| function(callbackName, callback) { |
| if (goog.isNull(this.readCallbacks_)) { |
| this.readCallbacks_ = {}; |
| } |
| goog.asserts.assert(!this.readCallbacks_[callbackName]); |
| this.readCallbacks_[callbackName] = callback; |
| }; |
| |
| |
| /** |
| * Runs a registered read callback. |
| * @param {string} callbackName The name the callback is registered under. |
| * @return {*} The value returned by the callback. |
| */ |
| jspb.BinaryReader.prototype.runReadCallback = function(callbackName) { |
| goog.asserts.assert(!goog.isNull(this.readCallbacks_)); |
| var callback = this.readCallbacks_[callbackName]; |
| goog.asserts.assert(callback); |
| return callback(this); |
| }; |
| |
| |
| /** |
| * Reads a field of any valid non-message type from the binary stream. |
| * @param {jspb.BinaryConstants.FieldType} fieldType |
| * @return {jspb.AnyFieldType} |
| */ |
| jspb.BinaryReader.prototype.readAny = function(fieldType) { |
| this.nextWireType_ = jspb.BinaryConstants.FieldTypeToWireType(fieldType); |
| var fieldTypes = jspb.BinaryConstants.FieldType; |
| switch (fieldType) { |
| case fieldTypes.DOUBLE: |
| return this.readDouble(); |
| case fieldTypes.FLOAT: |
| return this.readFloat(); |
| case fieldTypes.INT64: |
| return this.readInt64(); |
| case fieldTypes.UINT64: |
| return this.readUint64(); |
| case fieldTypes.INT32: |
| return this.readInt32(); |
| case fieldTypes.FIXED64: |
| return this.readFixed64(); |
| case fieldTypes.FIXED32: |
| return this.readFixed32(); |
| case fieldTypes.BOOL: |
| return this.readBool(); |
| case fieldTypes.STRING: |
| return this.readString(); |
| case fieldTypes.GROUP: |
| goog.asserts.fail('Group field type not supported in readAny()'); |
| case fieldTypes.MESSAGE: |
| goog.asserts.fail('Message field type not supported in readAny()'); |
| case fieldTypes.BYTES: |
| return this.readBytes(); |
| case fieldTypes.UINT32: |
| return this.readUint32(); |
| case fieldTypes.ENUM: |
| return this.readEnum(); |
| case fieldTypes.SFIXED32: |
| return this.readSfixed32(); |
| case fieldTypes.SFIXED64: |
| return this.readSfixed64(); |
| case fieldTypes.SINT32: |
| return this.readSint32(); |
| case fieldTypes.SINT64: |
| return this.readSint64(); |
| case fieldTypes.FHASH64: |
| return this.readFixedHash64(); |
| case fieldTypes.VHASH64: |
| return this.readVarintHash64(); |
| default: |
| goog.asserts.fail('Invalid field type in readAny()'); |
| } |
| return 0; |
| }; |
| |
| |
| /** |
| * Deserialize a proto into the provided message object using the provided |
| * reader function. This function is templated as we currently have one client |
| * who is using manual deserialization instead of the code-generated versions. |
| * @template T |
| * @param {T} message |
| * @param {function(T, !jspb.BinaryReader)} reader |
| */ |
| jspb.BinaryReader.prototype.readMessage = function(message, reader) { |
| goog.asserts.assert( |
| this.nextWireType_ == jspb.BinaryConstants.WireType.DELIMITED); |
| |
| // Save the current endpoint of the decoder and move it to the end of the |
| // embedded message. |
| var oldEnd = this.decoder_.getEnd(); |
| var length = this.decoder_.readUnsignedVarint32(); |
| var newEnd = this.decoder_.getCursor() + length; |
| this.decoder_.setEnd(newEnd); |
| |
| // Deserialize the embedded message. |
| reader(message, this); |
| |
| // Advance the decoder past the embedded message and restore the endpoint. |
| this.decoder_.setCursor(newEnd); |
| this.decoder_.setEnd(oldEnd); |
| }; |
| |
| |
| /** |
| * Deserialize a proto into the provided message object using the provided |
| * reader function, assuming that the message is serialized as a group |
| * with the given tag. |
| * @template T |
| * @param {number} field |
| * @param {T} message |
| * @param {function(T, !jspb.BinaryReader)} reader |
| */ |
| jspb.BinaryReader.prototype.readGroup = |
| function(field, message, reader) { |
| // Ensure that the wire type is correct. |
| goog.asserts.assert( |
| this.nextWireType_ == jspb.BinaryConstants.WireType.START_GROUP); |
| // Ensure that the field number is correct. |
| goog.asserts.assert(this.nextField_ == field); |
| |
| // Deserialize the message. The deserialization will stop at an END_GROUP tag. |
| reader(message, this); |
| |
| if (!this.error_ && |
| this.nextWireType_ != jspb.BinaryConstants.WireType.END_GROUP) { |
| goog.asserts.fail('Group submessage did not end with an END_GROUP tag'); |
| this.error_ = true; |
| } |
| }; |
| |
| |
| /** |
| * Return a decoder that wraps the current delimited field. |
| * @return {!jspb.BinaryDecoder} |
| */ |
| jspb.BinaryReader.prototype.getFieldDecoder = function() { |
| goog.asserts.assert( |
| this.nextWireType_ == jspb.BinaryConstants.WireType.DELIMITED); |
| |
| var length = this.decoder_.readUnsignedVarint32(); |
| var start = this.decoder_.getCursor(); |
| var end = start + length; |
| |
| var innerDecoder = |
| jspb.BinaryDecoder.alloc(this.decoder_.getBuffer(), start, length); |
| this.decoder_.setCursor(end); |
| return innerDecoder; |
| }; |
| |
| |
| /** |
| * Reads a signed 32-bit integer field from the binary stream, or throws an |
| * error if the next field in the stream is not of the correct wire type. |
| * |
| * @return {number} The value of the signed 32-bit integer field. |
| */ |
| jspb.BinaryReader.prototype.readInt32 = function() { |
| goog.asserts.assert( |
| this.nextWireType_ == jspb.BinaryConstants.WireType.VARINT); |
| return this.decoder_.readSignedVarint32(); |
| }; |
| |
| |
| /** |
| * Reads a signed 32-bit integer field from the binary stream, or throws an |
| * error if the next field in the stream is not of the correct wire type. |
| * |
| * Returns the value as a string. |
| * |
| * @return {string} The value of the signed 32-bit integer field as a decimal |
| * string. |
| */ |
| jspb.BinaryReader.prototype.readInt32String = function() { |
| goog.asserts.assert( |
| this.nextWireType_ == jspb.BinaryConstants.WireType.VARINT); |
| return this.decoder_.readSignedVarint32String(); |
| }; |
| |
| |
| /** |
| * Reads a signed 64-bit integer field from the binary stream, or throws an |
| * error if the next field in the stream is not of the correct wire type. |
| * |
| * @return {number} The value of the signed 64-bit integer field. |
| */ |
| jspb.BinaryReader.prototype.readInt64 = function() { |
| goog.asserts.assert( |
| this.nextWireType_ == jspb.BinaryConstants.WireType.VARINT); |
| return this.decoder_.readSignedVarint64(); |
| }; |
| |
| |
| /** |
| * Reads a signed 64-bit integer field from the binary stream, or throws an |
| * error if the next field in the stream is not of the correct wire type. |
| * |
| * Returns the value as a string. |
| * |
| * @return {string} The value of the signed 64-bit integer field as a decimal |
| * string. |
| */ |
| jspb.BinaryReader.prototype.readInt64String = function() { |
| goog.asserts.assert( |
| this.nextWireType_ == jspb.BinaryConstants.WireType.VARINT); |
| return this.decoder_.readSignedVarint64String(); |
| }; |
| |
| |
| /** |
| * Reads an unsigned 32-bit integer field from the binary stream, or throws an |
| * error if the next field in the stream is not of the correct wire type. |
| * |
| * @return {number} The value of the unsigned 32-bit integer field. |
| */ |
| jspb.BinaryReader.prototype.readUint32 = function() { |
| goog.asserts.assert( |
| this.nextWireType_ == jspb.BinaryConstants.WireType.VARINT); |
| return this.decoder_.readUnsignedVarint32(); |
| }; |
| |
| |
| /** |
| * Reads an unsigned 32-bit integer field from the binary stream, or throws an |
| * error if the next field in the stream is not of the correct wire type. |
| * |
| * Returns the value as a string. |
| * |
| * @return {string} The value of the unsigned 32-bit integer field as a decimal |
| * string. |
| */ |
| jspb.BinaryReader.prototype.readUint32String = function() { |
| goog.asserts.assert( |
| this.nextWireType_ == jspb.BinaryConstants.WireType.VARINT); |
| return this.decoder_.readUnsignedVarint32String(); |
| }; |
| |
| |
| /** |
| * Reads an unsigned 64-bit integer field from the binary stream, or throws an |
| * error if the next field in the stream is not of the correct wire type. |
| * |
| * @return {number} The value of the unsigned 64-bit integer field. |
| */ |
| jspb.BinaryReader.prototype.readUint64 = function() { |
| goog.asserts.assert( |
| this.nextWireType_ == jspb.BinaryConstants.WireType.VARINT); |
| return this.decoder_.readUnsignedVarint64(); |
| }; |
| |
| |
| /** |
| * Reads an unsigned 64-bit integer field from the binary stream, or throws an |
| * error if the next field in the stream is not of the correct wire type. |
| * |
| * Returns the value as a string. |
| * |
| * @return {string} The value of the unsigned 64-bit integer field as a decimal |
| * string. |
| */ |
| jspb.BinaryReader.prototype.readUint64String = function() { |
| goog.asserts.assert( |
| this.nextWireType_ == jspb.BinaryConstants.WireType.VARINT); |
| return this.decoder_.readUnsignedVarint64String(); |
| }; |
| |
| |
| /** |
| * Reads a signed zigzag-encoded 32-bit integer field from the binary stream, |
| * or throws an error if the next field in the stream is not of the correct |
| * wire type. |
| * |
| * @return {number} The value of the signed 32-bit integer field. |
| */ |
| jspb.BinaryReader.prototype.readSint32 = function() { |
| goog.asserts.assert( |
| this.nextWireType_ == jspb.BinaryConstants.WireType.VARINT); |
| return this.decoder_.readZigzagVarint32(); |
| }; |
| |
| |
| /** |
| * Reads a signed zigzag-encoded 64-bit integer field from the binary stream, |
| * or throws an error if the next field in the stream is not of the correct |
| * wire type. |
| * |
| * @return {number} The value of the signed 64-bit integer field. |
| */ |
| jspb.BinaryReader.prototype.readSint64 = function() { |
| goog.asserts.assert( |
| this.nextWireType_ == jspb.BinaryConstants.WireType.VARINT); |
| return this.decoder_.readZigzagVarint64(); |
| }; |
| |
| |
| /** |
| * Reads a signed zigzag-encoded 64-bit integer field from the binary stream, |
| * or throws an error if the next field in the stream is not of the correct |
| * wire type. |
| * |
| * @return {string} The value of the signed 64-bit integer field as a decimal string. |
| */ |
| jspb.BinaryReader.prototype.readSint64String = function() { |
| goog.asserts.assert( |
| this.nextWireType_ == jspb.BinaryConstants.WireType.VARINT); |
| return this.decoder_.readZigzagVarint64String(); |
| }; |
| |
| |
| /** |
| * Reads an unsigned 32-bit fixed-length integer fiield from the binary stream, |
| * or throws an error if the next field in the stream is not of the correct |
| * wire type. |
| * |
| * @return {number} The value of the double field. |
| */ |
| jspb.BinaryReader.prototype.readFixed32 = function() { |
| goog.asserts.assert( |
| this.nextWireType_ == jspb.BinaryConstants.WireType.FIXED32); |
| return this.decoder_.readUint32(); |
| }; |
| |
| |
| /** |
| * Reads an unsigned 64-bit fixed-length integer fiield from the binary stream, |
| * or throws an error if the next field in the stream is not of the correct |
| * wire type. |
| * |
| * @return {number} The value of the float field. |
| */ |
| jspb.BinaryReader.prototype.readFixed64 = function() { |
| goog.asserts.assert( |
| this.nextWireType_ == jspb.BinaryConstants.WireType.FIXED64); |
| return this.decoder_.readUint64(); |
| }; |
| |
| |
| /** |
| * Reads a signed 64-bit integer field from the binary stream as a string, or |
| * throws an error if the next field in the stream is not of the correct wire |
| * type. |
| * |
| * Returns the value as a string. |
| * |
| * @return {string} The value of the unsigned 64-bit integer field as a decimal |
| * string. |
| */ |
| jspb.BinaryReader.prototype.readFixed64String = function() { |
| goog.asserts.assert( |
| this.nextWireType_ == jspb.BinaryConstants.WireType.FIXED64); |
| return this.decoder_.readUint64String(); |
| }; |
| |
| |
| /** |
| * Reads a signed 32-bit fixed-length integer fiield from the binary stream, or |
| * throws an error if the next field in the stream is not of the correct wire |
| * type. |
| * |
| * @return {number} The value of the signed 32-bit integer field. |
| */ |
| jspb.BinaryReader.prototype.readSfixed32 = function() { |
| goog.asserts.assert( |
| this.nextWireType_ == jspb.BinaryConstants.WireType.FIXED32); |
| return this.decoder_.readInt32(); |
| }; |
| |
| |
| /** |
| * Reads a signed 32-bit fixed-length integer fiield from the binary stream, or |
| * throws an error if the next field in the stream is not of the correct wire |
| * type. |
| * |
| * @return {string} The value of the signed 32-bit integer field as a decimal |
| * string. |
| */ |
| jspb.BinaryReader.prototype.readSfixed32String = function() { |
| goog.asserts.assert( |
| this.nextWireType_ == jspb.BinaryConstants.WireType.FIXED32); |
| return this.decoder_.readInt32().toString(); |
| }; |
| |
| |
| /** |
| * Reads a signed 64-bit fixed-length integer fiield from the binary stream, or |
| * throws an error if the next field in the stream is not of the correct wire |
| * type. |
| * |
| * @return {number} The value of the sfixed64 field. |
| */ |
| jspb.BinaryReader.prototype.readSfixed64 = function() { |
| goog.asserts.assert( |
| this.nextWireType_ == jspb.BinaryConstants.WireType.FIXED64); |
| return this.decoder_.readInt64(); |
| }; |
| |
| |
| /** |
| * Reads a signed 64-bit fixed-length integer fiield from the binary stream, or |
| * throws an error if the next field in the stream is not of the correct wire |
| * type. |
| * |
| * Returns the value as a string. |
| * |
| * @return {string} The value of the sfixed64 field as a decimal string. |
| */ |
| jspb.BinaryReader.prototype.readSfixed64String = function() { |
| goog.asserts.assert( |
| this.nextWireType_ == jspb.BinaryConstants.WireType.FIXED64); |
| return this.decoder_.readInt64String(); |
| }; |
| |
| |
| /** |
| * Reads a 32-bit floating-point field from the binary stream, or throws an |
| * error if the next field in the stream is not of the correct wire type. |
| * |
| * @return {number} The value of the float field. |
| */ |
| jspb.BinaryReader.prototype.readFloat = function() { |
| goog.asserts.assert( |
| this.nextWireType_ == jspb.BinaryConstants.WireType.FIXED32); |
| return this.decoder_.readFloat(); |
| }; |
| |
| |
| /** |
| * Reads a 64-bit floating-point field from the binary stream, or throws an |
| * error if the next field in the stream is not of the correct wire type. |
| * |
| * @return {number} The value of the double field. |
| */ |
| jspb.BinaryReader.prototype.readDouble = function() { |
| goog.asserts.assert( |
| this.nextWireType_ == jspb.BinaryConstants.WireType.FIXED64); |
| return this.decoder_.readDouble(); |
| }; |
| |
| |
| /** |
| * Reads a boolean field from the binary stream, or throws an error if the next |
| * field in the stream is not of the correct wire type. |
| * |
| * @return {boolean} The value of the boolean field. |
| */ |
| jspb.BinaryReader.prototype.readBool = function() { |
| goog.asserts.assert( |
| this.nextWireType_ == jspb.BinaryConstants.WireType.VARINT); |
| return !!this.decoder_.readUnsignedVarint32(); |
| }; |
| |
| |
| /** |
| * Reads an enum field from the binary stream, or throws an error if the next |
| * field in the stream is not of the correct wire type. |
| * |
| * @return {number} The value of the enum field. |
| */ |
| jspb.BinaryReader.prototype.readEnum = function() { |
| goog.asserts.assert( |
| this.nextWireType_ == jspb.BinaryConstants.WireType.VARINT); |
| return this.decoder_.readSignedVarint64(); |
| }; |
| |
| |
| /** |
| * Reads a string field from the binary stream, or throws an error if the next |
| * field in the stream is not of the correct wire type. |
| * |
| * @return {string} The value of the string field. |
| */ |
| jspb.BinaryReader.prototype.readString = function() { |
| goog.asserts.assert( |
| this.nextWireType_ == jspb.BinaryConstants.WireType.DELIMITED); |
| var length = this.decoder_.readUnsignedVarint32(); |
| return this.decoder_.readString(length); |
| }; |
| |
| |
| /** |
| * Reads a length-prefixed block of bytes from the binary stream, or returns |
| * null if the next field in the stream has an invalid length value. |
| * |
| * @return {!Uint8Array} The block of bytes. |
| */ |
| jspb.BinaryReader.prototype.readBytes = function() { |
| goog.asserts.assert( |
| this.nextWireType_ == jspb.BinaryConstants.WireType.DELIMITED); |
| var length = this.decoder_.readUnsignedVarint32(); |
| return this.decoder_.readBytes(length); |
| }; |
| |
| |
| /** |
| * Reads a 64-bit varint or fixed64 field from the stream and returns it as a |
| * 8-character Unicode string for use as a hash table key, or throws an error |
| * if the next field in the stream is not of the correct wire type. |
| * |
| * @return {string} The hash value. |
| */ |
| jspb.BinaryReader.prototype.readVarintHash64 = function() { |
| goog.asserts.assert( |
| this.nextWireType_ == jspb.BinaryConstants.WireType.VARINT); |
| return this.decoder_.readVarintHash64(); |
| }; |
| |
| |
| /** |
| * Reads a 64-bit varint or fixed64 field from the stream and returns it as a |
| * 8-character Unicode string for use as a hash table key, or throws an error |
| * if the next field in the stream is not of the correct wire type. |
| * |
| * @return {string} The hash value. |
| */ |
| jspb.BinaryReader.prototype.readFixedHash64 = function() { |
| goog.asserts.assert( |
| this.nextWireType_ == jspb.BinaryConstants.WireType.FIXED64); |
| return this.decoder_.readFixedHash64(); |
| }; |
| |
| |
| /** |
| * Reads a packed scalar field using the supplied raw reader function. |
| * @param {function(this:jspb.BinaryDecoder)} decodeMethod |
| * @return {!Array} |
| * @private |
| */ |
| jspb.BinaryReader.prototype.readPackedField_ = function(decodeMethod) { |
| goog.asserts.assert( |
| this.nextWireType_ == jspb.BinaryConstants.WireType.DELIMITED); |
| var length = this.decoder_.readUnsignedVarint32(); |
| var end = this.decoder_.getCursor() + length; |
| var result = []; |
| while (this.decoder_.getCursor() < end) { |
| // TODO(aappleby): .call is slow |
| result.push(decodeMethod.call(this.decoder_)); |
| } |
| return result; |
| }; |
| |
| |
| /** |
| * Reads a packed int32 field, which consists of a length header and a list of |
| * signed varints. |
| * @return {!Array<number>} |
| */ |
| jspb.BinaryReader.prototype.readPackedInt32 = function() { |
| return this.readPackedField_(this.decoder_.readSignedVarint32); |
| }; |
| |
| |
| /** |
| * Reads a packed int32 field, which consists of a length header and a list of |
| * signed varints. Returns a list of strings. |
| * @return {!Array<string>} |
| */ |
| jspb.BinaryReader.prototype.readPackedInt32String = function() { |
| return this.readPackedField_(this.decoder_.readSignedVarint32String); |
| }; |
| |
| |
| /** |
| * Reads a packed int64 field, which consists of a length header and a list of |
| * signed varints. |
| * @return {!Array<number>} |
| */ |
| jspb.BinaryReader.prototype.readPackedInt64 = function() { |
| return this.readPackedField_(this.decoder_.readSignedVarint64); |
| }; |
| |
| |
| /** |
| * Reads a packed int64 field, which consists of a length header and a list of |
| * signed varints. Returns a list of strings. |
| * @return {!Array<string>} |
| */ |
| jspb.BinaryReader.prototype.readPackedInt64String = function() { |
| return this.readPackedField_(this.decoder_.readSignedVarint64String); |
| }; |
| |
| |
| /** |
| * Reads a packed uint32 field, which consists of a length header and a list of |
| * unsigned varints. |
| * @return {!Array<number>} |
| */ |
| jspb.BinaryReader.prototype.readPackedUint32 = function() { |
| return this.readPackedField_(this.decoder_.readUnsignedVarint32); |
| }; |
| |
| |
| /** |
| * Reads a packed uint32 field, which consists of a length header and a list of |
| * unsigned varints. Returns a list of strings. |
| * @return {!Array<string>} |
| */ |
| jspb.BinaryReader.prototype.readPackedUint32String = function() { |
| return this.readPackedField_(this.decoder_.readUnsignedVarint32String); |
| }; |
| |
| |
| /** |
| * Reads a packed uint64 field, which consists of a length header and a list of |
| * unsigned varints. |
| * @return {!Array<number>} |
| */ |
| jspb.BinaryReader.prototype.readPackedUint64 = function() { |
| return this.readPackedField_(this.decoder_.readUnsignedVarint64); |
| }; |
| |
| |
| /** |
| * Reads a packed uint64 field, which consists of a length header and a list of |
| * unsigned varints. Returns a list of strings. |
| * @return {!Array<string>} |
| */ |
| jspb.BinaryReader.prototype.readPackedUint64String = function() { |
| return this.readPackedField_(this.decoder_.readUnsignedVarint64String); |
| }; |
| |
| |
| /** |
| * Reads a packed sint32 field, which consists of a length header and a list of |
| * zigzag varints. |
| * @return {!Array<number>} |
| */ |
| jspb.BinaryReader.prototype.readPackedSint32 = function() { |
| return this.readPackedField_(this.decoder_.readZigzagVarint32); |
| }; |
| |
| |
| /** |
| * Reads a packed sint64 field, which consists of a length header and a list of |
| * zigzag varints. |
| * @return {!Array<number>} |
| */ |
| jspb.BinaryReader.prototype.readPackedSint64 = function() { |
| return this.readPackedField_(this.decoder_.readZigzagVarint64); |
| }; |
| |
| |
| /** |
| * Reads a packed sint64 field, which consists of a length header and a list of |
| * zigzag varints. Returns a list of strings. |
| * @return {!Array<string>} |
| */ |
| jspb.BinaryReader.prototype.readPackedSint64String = function() { |
| return this.readPackedField_(this.decoder_.readZigzagVarint64String); |
| }; |
| |
| |
| /** |
| * Reads a packed fixed32 field, which consists of a length header and a list |
| * of unsigned 32-bit ints. |
| * @return {!Array<number>} |
| */ |
| jspb.BinaryReader.prototype.readPackedFixed32 = function() { |
| return this.readPackedField_(this.decoder_.readUint32); |
| }; |
| |
| |
| /** |
| * Reads a packed fixed64 field, which consists of a length header and a list |
| * of unsigned 64-bit ints. |
| * @return {!Array<number>} |
| */ |
| jspb.BinaryReader.prototype.readPackedFixed64 = function() { |
| return this.readPackedField_(this.decoder_.readUint64); |
| }; |
| |
| |
| /** |
| * Reads a packed fixed64 field, which consists of a length header and a list |
| * of unsigned 64-bit ints. Returns a list of strings. |
| * @return {!Array<number>} |
| */ |
| jspb.BinaryReader.prototype.readPackedFixed64String = function() { |
| return this.readPackedField_(this.decoder_.readUint64String); |
| }; |
| |
| |
| /** |
| * Reads a packed sfixed32 field, which consists of a length header and a list |
| * of 32-bit ints. |
| * @return {!Array<number>} |
| */ |
| jspb.BinaryReader.prototype.readPackedSfixed32 = function() { |
| return this.readPackedField_(this.decoder_.readInt32); |
| }; |
| |
| |
| /** |
| * Reads a packed sfixed64 field, which consists of a length header and a list |
| * of 64-bit ints. |
| * @return {!Array<number>} |
| */ |
| jspb.BinaryReader.prototype.readPackedSfixed64 = function() { |
| return this.readPackedField_(this.decoder_.readInt64); |
| }; |
| |
| |
| /** |
| * Reads a packed sfixed64 field, which consists of a length header and a list |
| * of 64-bit ints. Returns a list of strings. |
| * @return {!Array<string>} |
| */ |
| jspb.BinaryReader.prototype.readPackedSfixed64String = function() { |
| return this.readPackedField_(this.decoder_.readInt64String); |
| }; |
| |
| |
| /** |
| * Reads a packed float field, which consists of a length header and a list of |
| * floats. |
| * @return {!Array<number>} |
| */ |
| jspb.BinaryReader.prototype.readPackedFloat = function() { |
| return this.readPackedField_(this.decoder_.readFloat); |
| }; |
| |
| |
| /** |
| * Reads a packed double field, which consists of a length header and a list of |
| * doubles. |
| * @return {!Array<number>} |
| */ |
| jspb.BinaryReader.prototype.readPackedDouble = function() { |
| return this.readPackedField_(this.decoder_.readDouble); |
| }; |
| |
| |
| /** |
| * Reads a packed bool field, which consists of a length header and a list of |
| * unsigned varints. |
| * @return {!Array<boolean>} |
| */ |
| jspb.BinaryReader.prototype.readPackedBool = function() { |
| return this.readPackedField_(this.decoder_.readBool); |
| }; |
| |
| |
| /** |
| * Reads a packed enum field, which consists of a length header and a list of |
| * unsigned varints. |
| * @return {!Array<number>} |
| */ |
| jspb.BinaryReader.prototype.readPackedEnum = function() { |
| return this.readPackedField_(this.decoder_.readEnum); |
| }; |
| |
| |
| /** |
| * Reads a packed varint hash64 field, which consists of a length header and a |
| * list of varint hash64s. |
| * @return {!Array<string>} |
| */ |
| jspb.BinaryReader.prototype.readPackedVarintHash64 = function() { |
| return this.readPackedField_(this.decoder_.readVarintHash64); |
| }; |
| |
| |
| /** |
| * Reads a packed fixed hash64 field, which consists of a length header and a |
| * list of fixed hash64s. |
| * @return {!Array<string>} |
| */ |
| jspb.BinaryReader.prototype.readPackedFixedHash64 = function() { |
| return this.readPackedField_(this.decoder_.readFixedHash64); |
| }; |