1220 lines
36 KiB
JavaScript
1220 lines
36 KiB
JavaScript
// 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);
|
|
};
|