// 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.} */ this.readCallbacks_ = null; }; /** * Global pool of BinaryReader instances. * @private {!Array.} */ 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()} 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.} */ 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.} */ 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.} */ 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.} */ 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.} */ 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.} */ 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.} */ 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.} */ 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.} */ 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.} */ 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.} */ 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.} */ 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.} */ 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.} */ 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.} */ 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.} */ 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.} */ 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.} */ 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.} */ 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.} */ 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.} */ 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.} */ 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.} */ jspb.BinaryReader.prototype.readPackedFixedHash64 = function() { return this.readPackedField_(this.decoder_.readFixedHash64); };