function defineInstanceMembers() {
  /**
   * Sets the protocol version and the encoding/decoding methods depending on the protocol version
   * @param {Number} value
   * @ignore
   * @internal
   */
  this.setProtocolVersion = function (value) {
    this.protocolVersion = value;
    //Set the collection serialization based on the protocol version
    this.decodeCollectionLength = decodeCollectionLengthV3;
    this.getLengthBuffer = getLengthBufferV3;
    this.collectionLengthSize = 4;
    if (!types.protocolVersion.uses4BytesCollectionLength(this.protocolVersion)) {
      this.decodeCollectionLength = decodeCollectionLengthV2;
      this.getLengthBuffer = getLengthBufferV2;
      this.collectionLengthSize = 2;
    }
  };
  const customDecoders = {};
  const customEncoders = {};
  // Decoding methods
  this.decodeBlob = function (bytes) {
    return this.handleBuffer(bytes);
  };
  this.decodeCustom = function (bytes, typeName) {
    const handler = customDecoders[typeName];
    if (handler) {
      return handler.call(this, bytes);
    }
    return this.handleBuffer(bytes);
  };
  this.decodeDuration = function (bytes) {
    return types.Duration.fromBuffer(bytes);
  };
  this.decodeUtf8String = function (bytes) {
    return bytes.toString('utf8');
  };
  this.decodeAsciiString = function (bytes) {
    return bytes.toString('ascii');
  };
  this.decodeBoolean = function (bytes) {
    return !!bytes.readUInt8(0);
  };
  this.decodeDouble = function (bytes) {
    return bytes.readDoubleBE(0);
  };
  this.decodeFloat = function (bytes) {
    return bytes.readFloatBE(0);
  };
  this.decodeInt = function (bytes) {
    return bytes.readInt32BE(0);
  };
  this.decodeSmallint = function (bytes) {
    return bytes.readInt16BE(0);
  };
  this.decodeTinyint = function (bytes) {
    return bytes.readInt8(0);
  };

  this._decodeCqlLongAsLong = function (bytes) {
    return Long.fromBuffer(bytes);
  };

  this._decodeCqlLongAsBigInt = function (bytes) {
    return BigInt.asIntN(64, (BigInt(bytes.readUInt32BE(0)) << bigInt32) | BigInt(bytes.readUInt32BE(4)));
  };

  this.decodeLong = this.encodingOptions.useBigIntAsLong
    ? this._decodeCqlLongAsBigInt
    : this._decodeCqlLongAsLong;

  this._decodeVarintAsInteger = function (bytes) {
    return Integer.fromBuffer(bytes);
  };

  this._decodeVarintAsBigInt = function decodeVarintAsBigInt(bytes) {
    let result = bigInt0;
    if (bytes[0] <= 0x7f) {
      for (let i = 0; i < bytes.length; i++) {
        const b = BigInt(bytes[bytes.length - 1 - i]);
        result = result | (b << BigInt(i * 8));
      }
    } else {
      for (let i = 0; i < bytes.length; i++) {
        const b = BigInt(bytes[bytes.length - 1 - i]);
        result = result | ((~b & bigInt8BitsOn) << BigInt(i * 8));
      }
      result = ~result;
    }

    return result;
  };

  this.decodeVarint = this.encodingOptions.useBigIntAsVarint
    ? this._decodeVarintAsBigInt
    : this._decodeVarintAsInteger;

  this.decodeDecimal = function(bytes) {
    return BigDecimal.fromBuffer(bytes);
  };
  this.decodeTimestamp = function(bytes) {
    return new Date(this._decodeCqlLongAsLong(bytes).toNumber());
  };
  this.decodeDate = function (bytes) {
    return types.LocalDate.fromBuffer(bytes);
  };
  this.decodeTime = function (bytes) {
    return types.LocalTime.fromBuffer(bytes);
  };
  /*
   * Reads a list from bytes
   */
  this.decodeList = function (bytes, subtype) {
    const totalItems = this.decodeCollectionLength(bytes, 0);
    let offset = this.collectionLengthSize;
    const list = new Array(totalItems);
    for (let i = 0; i < totalItems; i++) {
      //bytes length of the item
      const length = this.decodeCollectionLength(bytes, offset);
      offset += this.collectionLengthSize;
      //slice it
      list[i] = this.decode(bytes.slice(offset, offset+length), subtype);
      offset += length;
    }
    return list;
  };
  /*
   * Reads a Set from bytes
   */
  this.decodeSet = function (bytes, subtype) {
    const arr = this.decodeList(bytes, subtype);
    if (this.encodingOptions.set) {
      const setConstructor = this.encodingOptions.set;
      return new setConstructor(arr);
    }
    return arr;
  };
  /*
   * Reads a map (key / value) from bytes
   */
  this.decodeMap = function (bytes, subtypes) {
    let map;
    const totalItems = this.decodeCollectionLength(bytes, 0);
    let offset = this.collectionLengthSize;
    const self = this;
    function readValues(callback, thisArg) {
      for (let i = 0; i < totalItems; i++) {
        const keyLength = self.decodeCollectionLength(bytes, offset);
        offset += self.collectionLengthSize;
        const key = self.decode(bytes.slice(offset, offset + keyLength), subtypes[0]);
        offset += keyLength;
        const valueLength = self.decodeCollectionLength(bytes, offset);
        offset += self.collectionLengthSize;
        if (valueLength < 0) {
          callback.call(thisArg, key, null);
          continue;
        }
        const value = self.decode(bytes.slice(offset, offset + valueLength), subtypes[1]);
        offset += valueLength;
        callback.call(thisArg, key, value);
      }
    }
    if (this.encodingOptions.map) {
      const mapConstructor = this.encodingOptions.map;
      map = new mapConstructor();
      readValues(map.set, map);
    }
    else {
      map = {};
      readValues(function (key, value) {
        map[key] = value;
      });
    }
    return map;
  };
  this.decodeUuid = function (bytes) {
    return new types.Uuid(this.handleBuffer(bytes));
  };
  this.decodeTimeUuid = function (bytes) {
    return new types.TimeUuid(this.handleBuffer(bytes));
  };
  this.decodeInet = function (bytes) {
    return new types.InetAddress(this.handleBuffer(bytes));
  };
  /**
   * Decodes a user defined type into an object
   * @param {Buffer} bytes
   * @param {{fields: Array}} udtInfo
   * @private
   */
  this.decodeUdt = function (bytes, udtInfo) {
    const result = {};
    let offset = 0;
    for (let i = 0; i < udtInfo.fields.length && offset < bytes.length; i++) {
      //bytes length of the field value
      const length = bytes.readInt32BE(offset);
      offset += 4;
      //slice it
      const field = udtInfo.fields[i];
      if (length < 0) {
        result[field.name] = null;
        continue;
      }
      result[field.name] = this.decode(bytes.slice(offset, offset+length), field.type);
      offset += length;
    }
    return result;
  };
  this.decodeTuple = function (bytes, tupleInfo) {
    const elements = new Array(tupleInfo.length);
    let offset = 0;
    for (let i = 0; i < tupleInfo.length; i++) {
      const length = bytes.readInt32BE(offset);
      offset += 4;
      if (length < 0) {
        elements[i] = null;
        continue;
      }
      elements[i] = this.decode(bytes.slice(offset, offset+length), tupleInfo[i]);
      offset += length;
    }
    return new types.Tuple(elements);
  };
  //Encoding methods
  this.encodeFloat = function (value) {
    if (typeof value !== 'number') {
      throw new TypeError('Expected Number, obtained ' + util.inspect(value));
    }
    const buf = utils.allocBufferUnsafe(4);
    buf.writeFloatBE(value, 0);
    return buf;
  };
  this.encodeDouble = function (value) {
    if (typeof value !== 'number') {
      throw new TypeError('Expected Number, obtained ' + util.inspect(value));
    }
    const buf = utils.allocBufferUnsafe(8);
    buf.writeDoubleBE(value, 0);
    return buf;
  };
  /**
   * @param {Date|String|Long|Number} value
   * @private
   */
  this.encodeTimestamp = function (value) {
    const originalValue = value;
    if (typeof value === 'string') {
      value = new Date(value);
    }
    if (value instanceof Date) {
      //milliseconds since epoch
      value = value.getTime();
      if (isNaN(value)) {
        throw new TypeError('Invalid date: ' + originalValue);
      }
    }
    return this.encodeLong(value);
  };
  /**
   * @param {Date|String|LocalDate} value
   * @returns {Buffer}
   * @throws {TypeError}
   * @private
   */
  this.encodeDate = function (value) {
    const originalValue = value;
    try {
      if (typeof value === 'string') {
        value = types.LocalDate.fromString(value);
      }
      if (value instanceof Date) {
        value = types.LocalDate.fromDate(value);
      }
    }
    catch (err) {
      //Wrap into a TypeError
      throw new TypeError('LocalDate could not be parsed ' + err);
    }
    if (!(value instanceof types.LocalDate)) {
      throw new TypeError('Expected Date/String/LocalDate, obtained ' + util.inspect(originalValue));
    }
    return value.toBuffer();
  };
  /**
   * @param {String|LocalDate} value
   * @returns {Buffer}
   * @throws {TypeError}
   * @private
   */
  this.encodeTime = function (value) {
    const originalValue = value;
    try {
      if (typeof value === 'string') {
        value = types.LocalTime.fromString(value);
      }
    }
    catch (err) {
      //Wrap into a TypeError
      throw new TypeError('LocalTime could not be parsed ' + err);
    }
    if (!(value instanceof types.LocalTime)) {
      throw new TypeError('Expected String/LocalTime, obtained ' + util.inspect(originalValue));
    }
    return value.toBuffer();
  };
  /**
   * @param {Uuid|String|Buffer} value
   * @private
   */
  this.encodeUuid = function (value) {
    if (typeof value === 'string') {
      try {
        value = types.Uuid.fromString(value).getBuffer();
      }
      catch (err) {
        throw new TypeError(err.message);
      }
    } else if (value instanceof types.Uuid) {
      value = value.getBuffer();
    } else {
      throw new TypeError('Not a valid Uuid, expected Uuid/String/Buffer, obtained ' + util.inspect(value));
    }

    return value;
  };
  /**
   * @param {String|InetAddress|Buffer} value
   * @returns {Buffer}
   * @private
   */
  this.encodeInet = function (value) {
    if (typeof value === 'string') {
      value = types.InetAddress.fromString(value);
    }
    if (value instanceof types.InetAddress) {
      value = value.getBuffer();
    }
    if (!(value instanceof Buffer)) {
      throw new TypeError('Not a valid Inet, expected InetAddress/Buffer, obtained ' + util.inspect(value));
    }
    return value;
  };

  /**
   * @param {Long|Buffer|String|Number} value
   * @private
   */
  this._encodeBigIntFromLong = function (value) {
    if (typeof value === 'number') {
      value = Long.fromNumber(value);
    } else if (typeof value === 'string') {
      value = Long.fromString(value);
    }

    let buf = null;

    if (value instanceof Long) {
      buf = Long.toBuffer(value);
    } else if (value instanceof MutableLong) {
      buf = Long.toBuffer(value.toImmutable());
    }

    if (buf === null) {
      throw new TypeError('Not a valid bigint, expected Long/Number/String/Buffer, obtained ' + util.inspect(value));
    }

    return buf;
  };

  this._encodeBigIntFromBigInt = function (value) {
    // eslint-disable-next-line valid-typeof
    if (typeof value !== 'bigint') {
      // Only BigInt values are supported
      throw new TypeError('Not a valid BigInt value, obtained ' + util.inspect(value));
    }

    const buffer = utils.allocBufferUnsafe(8);
    buffer.writeUInt32BE(Number(value >> bigInt32) >>> 0, 0);
    buffer.writeUInt32BE(Number(value & bigInt32BitsOn), 4);
    return buffer;
  };

  this.encodeLong = this.encodingOptions.useBigIntAsLong
    ? this._encodeBigIntFromBigInt
    : this._encodeBigIntFromLong;

  /**
   * @param {Integer|Buffer|String|Number} value
   * @returns {Buffer}
   * @private
   */
  this._encodeVarintFromInteger = function (value) {
    if (typeof value === 'number') {
      value = Integer.fromNumber(value);
    }
    if (typeof value === 'string') {
      value = Integer.fromString(value);
    }
    let buf = null;
    if (value instanceof Buffer) {
      buf = value;
    }
    if (value instanceof Integer) {
      buf = Integer.toBuffer(value);
    }
    if (buf === null) {
      throw new TypeError('Not a valid varint, expected Integer/Number/String/Buffer, obtained ' + util.inspect(value));
    }
    return buf;
  };

  this._encodeVarintFromBigInt = function (value) {
    // eslint-disable-next-line valid-typeof
    if (typeof value !== 'bigint') {
      throw new TypeError('Not a valid varint, expected BigInt, obtained ' + util.inspect(value));
    }

    if (value === bigInt0) {
      return buffers.int8Zero;

    }
    else if (value === bigIntMinus1) {
      return buffers.int8MaxValue;
    }

    const parts = [];

    if (value > bigInt0){
      while (value !== bigInt0) {
        parts.unshift(Number(value & bigInt8BitsOn));
        value = value >> bigInt8;
      }

      if (parts[0] > 0x7f) {
        // Positive value needs a padding
        parts.unshift(0);
      }
    } else {
      while (value !== bigIntMinus1) {
        parts.unshift(Number(value & bigInt8BitsOn));
        value = value >> bigInt8;
      }

      if (parts[0] <= 0x7f) {
        // Negative value needs a padding
        parts.unshift(0xff);
      }
    }

    return utils.allocBufferFromArray(parts);
  };

  this.encodeVarint = this.encodingOptions.useBigIntAsVarint
    ? this._encodeVarintFromBigInt
    : this._encodeVarintFromInteger;

  /**
   * @param {BigDecimal|Buffer|String|Number} value
   * @returns {Buffer}
   * @private
   */
  this.encodeDecimal = function (value) {
    if (typeof value === 'number') {
      value = BigDecimal.fromNumber(value);
    } else if (typeof value === 'string') {
      value = BigDecimal.fromString(value);
    }

    let buf = null;

    if (value instanceof BigDecimal) {
      buf = BigDecimal.toBuffer(value);
    } else {
      throw new TypeError('Not a valid varint, expected BigDecimal/Number/String/Buffer, obtained ' + util.inspect(value));
    }

    return buf;
  };
  this.encodeString = function (value, encoding) {
    if (typeof value !== 'string') {
      throw new TypeError('Not a valid text value, expected String obtained ' + util.inspect(value));
    }
    return utils.allocBufferFromString(value, encoding);
  };
  this.encodeUtf8String = function (value) {
    return this.encodeString(value, 'utf8');
  };
  this.encodeAsciiString = function (value) {
    return this.encodeString(value, 'ascii');
  };
  this.encodeBlob = function (value) {
    if (!(value instanceof Buffer)) {
      throw new TypeError('Not a valid blob, expected Buffer obtained ' + util.inspect(value));
    }
    return value;
  };
  this.encodeCustom = function (value, name) {
    const handler = customEncoders[name];
    if (handler) {
      return handler.call(this, value);
    }
    throw new TypeError('No encoding handler found for type ' + name);
  };
  this.encodeDuration = function (value) {
    if (!(value instanceof types.Duration)) {
      throw new TypeError('Not a valid duration, expected Duration/Buffer obtained ' + util.inspect(value));
    }
    return value.toBuffer();
  };
  /**
   * @param {Boolean} value
   * @returns {Buffer}
   * @private
   */
  this.encodeBoolean = function (value) {
    return value ? buffers.int8One : buffers.int8Zero;
  };
  /**
   * @param {Number|String} value
   * @private
   */
  this.encodeInt = function (value) {
    if (isNaN(value)) {
      throw new TypeError('Expected Number, obtained ' + util.inspect(value));
    }
    const buf = utils.allocBufferUnsafe(4);
    buf.writeInt32BE(value, 0);
    return buf;
  };
  /**
   * @param {Number|String} value
   * @private
   */
  this.encodeSmallint = function (value) {
    if (isNaN(value)) {
      throw new TypeError('Expected Number, obtained ' + util.inspect(value));
    }
    const buf = utils.allocBufferUnsafe(2);
    buf.writeInt16BE(value, 0);
    return buf;
  };
  /**
   * @param {Number|String} value
   * @private
   */
  this.encodeTinyint = function (value) {
    if (isNaN(value)) {
      throw new TypeError('Expected Number, obtained ' + util.inspect(value));
    }
    const buf = utils.allocBufferUnsafe(1);
    buf.writeInt8(value, 0);
    return buf;
  };
  this.encodeList = function (value, subtype) {
    if (!util.isArray(value)) {
      throw new TypeError('Not a valid list value, expected Array obtained ' + util.inspect(value));
    }
    if (value.length === 0) {
      return null;
    }
    const parts = [];
    parts.push(this.getLengthBuffer(value));
    for (let i = 0;i < value.length;i++) {
      const val = value[i];
      if (val === null || typeof val === 'undefined' || val === types.unset) {
        throw new TypeError('A collection can\'t contain null or unset values');
      }
      const bytes = this.encode(val, subtype);
      //include item byte length
      parts.push(this.getLengthBuffer(bytes));
      //include item
      parts.push(bytes);
    }
    return Buffer.concat(parts);
  };
  this.encodeSet = function (value, subtype) {
    if (this.encodingOptions.set && value instanceof this.encodingOptions.set) {
      const arr = [];
      value.forEach(function (x) {
        arr.push(x);
      });
      return this.encodeList(arr, subtype);
    }
    return this.encodeList(value, subtype);
  };
  /**
   * Serializes a map into a Buffer
   * @param value
   * @param {Array} [subtypes]
   * @returns {Buffer}
   * @private
   */
  this.encodeMap = function (value, subtypes) {
    const parts = [];
    let propCounter = 0;
    let keySubtype = null;
    let valueSubtype = null;
    const self = this;
    if (subtypes) {
      keySubtype = subtypes[0];
      valueSubtype = subtypes[1];
    }
    function addItem(val, key) {
      if (key === null || typeof key === 'undefined' || key === types.unset) {
        throw new TypeError('A map can\'t contain null or unset keys');
      }
      if (val === null || typeof val === 'undefined' || val === types.unset) {
        throw new TypeError('A map can\'t contain null or unset values');
      }
      const keyBuffer = self.encode(key, keySubtype);
      //include item byte length
      parts.push(self.getLengthBuffer(keyBuffer));
      //include item
      parts.push(keyBuffer);
      //value
      const valueBuffer = self.encode(val, valueSubtype);
      //include item byte length
      parts.push(self.getLengthBuffer(valueBuffer));
      //include item
      if (valueBuffer !== null) {
        parts.push(valueBuffer);
      }
      propCounter++;
    }
    if (this.encodingOptions.map && value instanceof this.encodingOptions.map) {
      //Use Map#forEach() method to iterate
      value.forEach(addItem);
    }
    else {
      //Use object
      for (const key in value) {
        if (!value.hasOwnProperty(key)) {
          continue;
        }
        const val = value[key];
        addItem(val, key);
      }
    }

    parts.unshift(this.getLengthBuffer(propCounter));
    return Buffer.concat(parts);
  };
  this.encodeUdt = function (value, udtInfo) {
    const parts = [];
    let totalLength = 0;
    for (let i = 0; i < udtInfo.fields.length; i++) {
      const field = udtInfo.fields[i];
      const item = this.encode(value[field.name], field.type);
      if (!item) {
        parts.push(nullValueBuffer);
        totalLength += 4;
        continue;
      }
      if (item === types.unset) {
        parts.push(unsetValueBuffer);
        totalLength += 4;
        continue;
      }
      const lengthBuffer = utils.allocBufferUnsafe(4);
      lengthBuffer.writeInt32BE(item.length, 0);
      parts.push(lengthBuffer);
      parts.push(item);
      totalLength += item.length + 4;
    }
    return Buffer.concat(parts, totalLength);
  };
  this.encodeTuple = function (value, tupleInfo) {
    const parts = [];
    let totalLength = 0;
    for (let i = 0; i < tupleInfo.length; i++) {
      const type = tupleInfo[i];
      const item = this.encode(value.get(i), type);
      if (!item) {
        parts.push(nullValueBuffer);
        totalLength += 4;
        continue;
      }
      if (item === types.unset) {
        parts.push(unsetValueBuffer);
        totalLength += 4;
        continue;
      }
      const lengthBuffer = utils.allocBufferUnsafe(4);
      lengthBuffer.writeInt32BE(item.length, 0);
      parts.push(lengthBuffer);
      parts.push(item);
      totalLength += item.length + 4;
    }
    return Buffer.concat(parts, totalLength);
  };

  /**
   * If not provided, it uses the array of buffers or the parameters and hints to build the routingKey
   * @param {Array} params
   * @param {ExecutionOptions} execOptions
   * @param [keys] parameter keys and positions in the params array
   * @throws TypeError
   * @internal
   * @ignore
   */
  this.setRoutingKeyFromUser = function (params, execOptions, keys) {
    let totalLength = 0;
    const userRoutingKey = execOptions.getRoutingKey();
    if (util.isArray(userRoutingKey)) {
      if (userRoutingKey.length === 1) {
        execOptions.setRoutingKey(userRoutingKey[0]);
        return;
      }

      // Its a composite routing key
      totalLength = 0;
      for (let i = 0; i < userRoutingKey.length; i++) {
        const item = userRoutingKey[i];
        if (!item) {
          // Invalid routing key part provided by the user, clear the value
          execOptions.setRoutingKey(null);
          return;
        }
        totalLength += item.length + 3;
      }

      execOptions.setRoutingKey(concatRoutingKey(userRoutingKey, totalLength));
      return;
    }
    // If routingKey is present, ensure it is a Buffer, Token, or TokenRange.  Otherwise throw an error.
    if (userRoutingKey) {
      if (userRoutingKey instanceof Buffer || userRoutingKey instanceof token.Token
        || userRoutingKey instanceof token.TokenRange) {
        return;
      }

      throw new TypeError(`Unexpected routingKey '${util.inspect(userRoutingKey)}' provided. ` +
        `Expected Buffer, Array<Buffer>, Token, or TokenRange.`);
    }

    // If no params are present, return as routing key cannot be determined.
    if (!params || params.length === 0) {
      return;
    }

    let routingIndexes = execOptions.getRoutingIndexes();
    if (execOptions.getRoutingNames()) {
      routingIndexes = execOptions.getRoutingNames().map(k => keys[k]);
    }
    if (!routingIndexes) {
      return;
    }

    const parts = [];
    const hints = execOptions.getHints() || utils.emptyArray;

    const encodeParam = !keys ?
      (i => this.encode(params[i], hints[i])) :
      (i => this.encode(params[i].value, hints[i]));

    try {
      totalLength = this._encodeRoutingKeyParts(parts, routingIndexes, encodeParam);
    } catch (e) {
      // There was an error encoding a parameter that is part of the routing key,
      // ignore now to fail afterwards
    }

    if (totalLength === 0) {
      return;
    }

    execOptions.setRoutingKey(concatRoutingKey(parts, totalLength));
  };

  /**
   * Sets the routing key in the options based on the prepared statement metadata.
   * @param {Object} meta Prepared metadata
   * @param {Array} params Array of parameters
   * @param {ExecutionOptions} execOptions
   * @throws TypeError
   * @internal
   * @ignore
   */
  this.setRoutingKeyFromMeta = function (meta, params, execOptions) {
    const routingIndexes = execOptions.getRoutingIndexes();
    if (!routingIndexes) {
      return;
    }
    const parts = new Array(routingIndexes.length);
    const encodeParam = i => {
      const columnInfo = meta.columns[i];
      return this.encode(params[i], columnInfo ? columnInfo.type : null);
    };

    let totalLength = 0;

    try {
      totalLength = this._encodeRoutingKeyParts(parts, routingIndexes, encodeParam);
    } catch (e) {
      // There was an error encoding a parameter that is part of the routing key,
      // ignore now to fail afterwards
    }

    if (totalLength === 0) {
      return;
    }

    execOptions.setRoutingKey(concatRoutingKey(parts, totalLength));
  };

  /**
   * @param {Array} parts
   * @param {Array} routingIndexes
   * @param {Function} encodeParam
   * @returns {Number} The total length
   * @private
   */
  this._encodeRoutingKeyParts = function (parts, routingIndexes, encodeParam) {
    let totalLength = 0;
    for (let i = 0; i < routingIndexes.length; i++) {
      const paramIndex = routingIndexes[i];
      if (paramIndex === undefined) {
        // Bad input from the user, ignore
        return 0;
      }

      const item = encodeParam(paramIndex);
      if (item === null || item === undefined || item === types.unset) {
        // The encoded partition key should an instance of Buffer
        // Let it fail later in the pipeline for null/undefined parameter values
        return 0;
      }

      // Per each part of the routing key, 3 extra bytes are needed
      totalLength += item.length + 3;
      parts[i] = item;
    }
    return totalLength;
  };

  /**
   * Parses a CQL name string into data type information
   * @param {String} keyspace
   * @param {String} typeName
   * @param {Number} startIndex
   * @param {Number|null} length
   * @param {Function} udtResolver
   * @param {Function} callback Callback invoked with err and  {{code: number, info: Object|Array|null, options: {frozen: Boolean}}}
   * @internal
   * @ignore
   */
  this.parseTypeName = function (keyspace, typeName, startIndex, length, udtResolver, callback) {
    startIndex = startIndex || 0;
    if (!length) {
      length = typeName.length;
    }
    const dataType = {
      code: 0,
      info: null,
      options: {
        frozen: false
      }
    };
    let innerTypes;
    if (typeName.indexOf("'", startIndex) === startIndex) {
      //If quoted, this is a custom type.
      dataType.info = typeName.substr(startIndex+1, length-2);
      return callback(null, dataType);
    }
    if (!length) {
      length = typeName.length;
    }
    if (typeName.indexOf(cqlNames.frozen, startIndex) === startIndex) {
      //Remove the frozen token
      startIndex += cqlNames.frozen.length + 1;
      length -= cqlNames.frozen.length + 2;
      dataType.options.frozen = true;
    }
    if (typeName.indexOf(cqlNames.list, startIndex) === startIndex) {
      //move cursor across the name and bypass the angle brackets
      startIndex += cqlNames.list.length + 1;
      length -= cqlNames.list.length + 2;
      innerTypes = parseParams(typeName, startIndex, length, '<', '>');
      if (innerTypes.length !== 1) {
        return callback(new TypeError('Not a valid type ' + typeName));
      }
      dataType.code = dataTypes.list;
      return this.parseTypeName(keyspace, innerTypes[0], 0, null, udtResolver, function (err, childType) {
        if (err) {
          return callback(err);
        }
        dataType.info = childType;
        callback(null, dataType);
      });
    }
    if (typeName.indexOf(cqlNames.set, startIndex) === startIndex) {
      //move cursor across the name and bypass the angle brackets
      startIndex += cqlNames.set.length + 1;
      length -= cqlNames.set.length + 2;
      innerTypes = parseParams(typeName, startIndex, length, '<', '>');
      if (innerTypes.length !== 1) {
        return callback(new TypeError('Not a valid type ' + typeName));
      }
      dataType.code = dataTypes.set;
      return this.parseTypeName(keyspace, innerTypes[0], 0, null, udtResolver, function (err, childType) {
        if (err) {
          return callback(err);
        }
        dataType.info = childType;
        callback(null, dataType);
      });
    }
    if (typeName.indexOf(cqlNames.map, startIndex) === startIndex) {
      //move cursor across the name and bypass the angle brackets
      startIndex += cqlNames.map.length + 1;
      length -= cqlNames.map.length + 2;
      innerTypes = parseParams(typeName, startIndex, length, '<', '>');
      //It should contain the key and value types
      if (innerTypes.length !== 2) {
        return callback(new TypeError('Not a valid type ' + typeName));
      }
      dataType.code = dataTypes.map;
      return this._parseChildTypes(keyspace, dataType, innerTypes, udtResolver, callback);
    }
    if (typeName.indexOf(cqlNames.tuple, startIndex) === startIndex) {
      //move cursor across the name and bypass the angle brackets
      startIndex += cqlNames.tuple.length + 1;
      length -= cqlNames.tuple.length + 2;
      innerTypes = parseParams(typeName, startIndex, length, '<', '>');
      if (innerTypes.length < 1) {
        throw new TypeError('Not a valid type ' + typeName);
      }
      dataType.code = dataTypes.tuple;
      return this._parseChildTypes(keyspace, dataType, innerTypes, udtResolver, callback);
    }
    const quoted = typeName.indexOf('"', startIndex) === startIndex;
    if (quoted) {
      //Remove quotes
      startIndex++;
      length -= 2;
    }
    //Quick check if its a single type
    if (startIndex > 0) {
      typeName = typeName.substr(startIndex, length);
    }
    // Un-escape double quotes if quoted.
    if (quoted) {
      typeName = typeName.replace('""', '"');
    }
    const typeCode = dataTypes[typeName];
    if (typeof typeCode === 'number') {
      dataType.code = typeCode;
      return callback(null, dataType);
    }
    if (typeName === cqlNames.duration) {
      dataType.info = durationTypeName;
      return callback(null, dataType);
    }
    if (typeName === cqlNames.empty) {
      //set as custom
      dataType.info = 'empty';
      return callback(null, dataType);
    }
    udtResolver(keyspace, typeName, function (err, udtInfo) {
      if (err) {
        return callback(err);
      }
      if (udtInfo) {
        dataType.code = dataTypes.udt;
        dataType.info = udtInfo;
        return callback(null, dataType);
      }
      callback(new TypeError('Not a valid type "' + typeName + '"'));
    });
  };
  /**
   * @param {String} keyspace
   * @param dataType
   * @param {Array} typeNames
   * @param {Function} udtResolver
   * @param {Function} callback
   * @private
   */
  this._parseChildTypes = function (keyspace, dataType, typeNames, udtResolver, callback) {
    const self = this;
    utils.mapSeries(typeNames, function (name, next) {
      self.parseTypeName(keyspace, name.trim(), 0, null, udtResolver, next);
    }, function (err, childTypes) {
      if (err) {
        return callback(err);
      }
      dataType.info = childTypes;
      callback(null, dataType);
    });
  };

  /**
   * Parses a Cassandra fully-qualified class name string into data type information
   * @param {String} typeName
   * @param {Number} [startIndex]
   * @param {Number} [length]
   * @throws TypeError
   * @returns {{code: number, info: Object|Array|null, options: {frozen: Boolean, reversed: Boolean}}}
   * @internal
   * @ignore
   */
  this.parseFqTypeName = function (typeName, startIndex, length) {
    const dataType = {
      code: 0,
      info: null,
      options: {
        reversed: false,
        frozen: false
      }
    };
    startIndex = startIndex || 0;
    let innerTypes;
    if (!length) {
      length = typeName.length;
    }
    if (length > complexTypeNames.reversed.length && typeName.indexOf(complexTypeNames.reversed) === startIndex) {
      //Remove the reversed token
      startIndex += complexTypeNames.reversed.length + 1;
      length -= complexTypeNames.reversed.length + 2;
      dataType.options.reversed = true;
    }
    if (length > complexTypeNames.frozen.length &&
        typeName.indexOf(complexTypeNames.frozen, startIndex) === startIndex) {
      //Remove the frozen token
      startIndex += complexTypeNames.frozen.length + 1;
      length -= complexTypeNames.frozen.length + 2;
      dataType.options.frozen = true;
    }
    if (typeName === complexTypeNames.empty) {
      //set as custom
      dataType.info = 'empty';
      return dataType;
    }
    //Quick check if its a single type
    if (length <= singleFqTypeNamesLength) {
      if (startIndex > 0) {
        typeName = typeName.substr(startIndex, length);
      }
      const typeCode = singleTypeNames[typeName];
      if (typeof typeCode === 'number') {
        dataType.code = typeCode;
        return dataType;
      }
      throw new TypeError('Not a valid type "' + typeName + '"');
    }
    if (typeName.indexOf(complexTypeNames.list, startIndex) === startIndex) {
      //Its a list
      //org.apache.cassandra.db.marshal.ListType(innerType)
      //move cursor across the name and bypass the parenthesis
      startIndex += complexTypeNames.list.length + 1;
      length -= complexTypeNames.list.length + 2;
      innerTypes = parseParams(typeName, startIndex, length);
      if (innerTypes.length !== 1) {
        throw new TypeError('Not a valid type ' + typeName);
      }
      dataType.code = dataTypes.list;
      dataType.info = this.parseFqTypeName(innerTypes[0]);
      return dataType;
    }
    if (typeName.indexOf(complexTypeNames.set, startIndex) === startIndex) {
      //Its a set
      //org.apache.cassandra.db.marshal.SetType(innerType)
      //move cursor across the name and bypass the parenthesis
      startIndex += complexTypeNames.set.length + 1;
      length -= complexTypeNames.set.length + 2;
      innerTypes = parseParams(typeName, startIndex, length);
      if (innerTypes.length !== 1)
      {
        throw new TypeError('Not a valid type ' + typeName);
      }
      dataType.code = dataTypes.set;
      dataType.info = this.parseFqTypeName(innerTypes[0]);
      return dataType;
    }
    if (typeName.indexOf(complexTypeNames.map, startIndex) === startIndex) {
      //org.apache.cassandra.db.marshal.MapType(keyType,valueType)
      //move cursor across the name and bypass the parenthesis
      startIndex += complexTypeNames.map.length + 1;
      length -= complexTypeNames.map.length + 2;
      innerTypes = parseParams(typeName, startIndex, length);
      //It should contain the key and value types
      if (innerTypes.length !== 2) {
        throw new TypeError('Not a valid type ' + typeName);
      }
      dataType.code = dataTypes.map;
      dataType.info = [this.parseFqTypeName(innerTypes[0]), this.parseFqTypeName(innerTypes[1])];
      return dataType;
    }
    if (typeName.indexOf(complexTypeNames.udt, startIndex) === startIndex) {
      //move cursor across the name and bypass the parenthesis
      startIndex += complexTypeNames.udt.length + 1;
      length -= complexTypeNames.udt.length + 2;
      return this._parseUdtName(typeName, startIndex, length);
    }
    if (typeName.indexOf(complexTypeNames.tuple, startIndex) === startIndex) {
      //move cursor across the name and bypass the parenthesis
      startIndex += complexTypeNames.tuple.length + 1;
      length -= complexTypeNames.tuple.length + 2;
      innerTypes = parseParams(typeName, startIndex, length);
      if (innerTypes.length < 1) {
        throw new TypeError('Not a valid type ' + typeName);
      }
      dataType.code = dataTypes.tuple;
      dataType.info = innerTypes.map(x => this.parseFqTypeName(x));
      return dataType;
    }

    // Assume custom type if cannot be parsed up to this point.
    dataType.info = typeName.substr(startIndex, length);
    return dataType;
  };
  /**
   * Parses type names with composites
   * @param {String} typesString
   * @returns {{types: Array, isComposite: Boolean, hasCollections: Boolean}}
   * @internal
   * @ignore
   */
  this.parseKeyTypes = function (typesString) {
    let i = 0;
    let length = typesString.length;
    const isComposite = typesString.indexOf(complexTypeNames.composite) === 0;
    if (isComposite) {
      i = complexTypeNames.composite.length + 1;
      length--;
    }
    const types = [];
    let startIndex = i;
    let nested = 0;
    let inCollectionType = false;
    let hasCollections = false;
    //as collection types are not allowed, it is safe to split by ,
    while (++i < length) {
      switch (typesString[i]) {
        case ',':
          if (nested > 0) {
            break;
          }
          if (inCollectionType) {
            //remove type id
            startIndex = typesString.indexOf(':', startIndex) + 1;
          }
          types.push(typesString.substring(startIndex, i));
          startIndex = i + 1;
          break;
        case '(':
          if (nested === 0 && typesString.indexOf(complexTypeNames.collection, startIndex) === startIndex) {
            inCollectionType = true;
            hasCollections = true;
            //skip collection type
            i++;
            startIndex = i;
            break;
          }
          nested++;
          break;
        case ')':
          if (inCollectionType && nested === 0){
            types.push(typesString.substring(typesString.indexOf(':', startIndex) + 1, i));
            startIndex = i + 1;
            break;
          }
          nested--;
          break;
      }
    }
    if (startIndex < length) {
      types.push(typesString.substring(startIndex, length));
    }
    return {
      types: types.map(name => this.parseFqTypeName(name)),
      hasCollections: hasCollections,
      isComposite: isComposite
    };
  };
  this._parseUdtName = function (typeName, startIndex, length) {
    const udtParams = parseParams(typeName, startIndex, length);
    if (udtParams.length < 2) {
      //It should contain at least the keyspace, name of the udt and a type
      throw new TypeError('Not a valid type ' + typeName);
    }
    const dataType = {
      code: dataTypes.udt,
      info: null
    };
    const udtInfo = {
      keyspace: udtParams[0],
      name: utils.allocBufferFromString(udtParams[1], 'hex').toString(),
      fields: []
    };
    for (let i = 2; i < udtParams.length; i++) {
      const p = udtParams[i];
      const separatorIndex = p.indexOf(':');
      const fieldType = this.parseFqTypeName(p, separatorIndex + 1, p.length - (separatorIndex + 1));
      udtInfo.fields.push({
        name: utils.allocBufferFromString(p.substr(0, separatorIndex), 'hex').toString(),
        type: fieldType
      });
    }
    dataType.info = udtInfo;
    return dataType;
  };

  customDecoders[durationTypeName] = this.decodeDuration;
  customEncoders[durationTypeName] = this.encodeDuration;
}
function defineInstanceMembers() {
  
  this.setProtocolVersion = function (value) {
    this.protocolVersion = value;
    
    this.decodeCollectionLength = decodeCollectionLengthV3;
    this.getLengthBuffer = getLengthBufferV3;
    this.collectionLengthSize = 4;
    if (!types.protocolVersion.uses4BytesCollectionLength(this.protocolVersion)) {
      this.decodeCollectionLength = decodeCollectionLengthV2;
      this.getLengthBuffer = getLengthBufferV2;
      this.collectionLengthSize = 2;
    }
  };
  const customDecoders = {};
  const customEncoders = {};
  
  this.decodeBlob = function (bytes) {
    return this.handleBuffer(bytes);
  };
  this.decodeCustom = function (bytes, typeName) {
    const handler = customDecoders[typeName];
    if (handler) {
      return handler.call(this, bytes);
    }
    return this.handleBuffer(bytes);
  };
  this.decodeDuration = function (bytes) {
    return types.Duration.fromBuffer(bytes);
  };
  this.decodeUtf8String = function (bytes) {
    return bytes.toString('utf8');
  };
  this.decodeAsciiString = function (bytes) {
    return bytes.toString('ascii');
  };
  this.decodeBoolean = function (bytes) {
    return !!bytes.readUInt8(0);
  };
  this.decodeDouble = function (bytes) {
    return bytes.readDoubleBE(0);
  };
  this.decodeFloat = function (bytes) {
    return bytes.readFloatBE(0);
  };
  this.decodeInt = function (bytes) {
    return bytes.readInt32BE(0);
  };
  this.decodeSmallint = function (bytes) {
    return bytes.readInt16BE(0);
  };
  this.decodeTinyint = function (bytes) {
    return bytes.readInt8(0);
  };

  this._decodeCqlLongAsLong = function (bytes) {
    return Long.fromBuffer(bytes);
  };

  this._decodeCqlLongAsBigInt = function (bytes) {
    return BigInt.asIntN(64, (BigInt(bytes.readUInt32BE(0)) << bigInt32) | BigInt(bytes.readUInt32BE(4)));
  };

  this.decodeLong = this.encodingOptions.useBigIntAsLong
    ? this._decodeCqlLongAsBigInt
    : this._decodeCqlLongAsLong;

  this._decodeVarintAsInteger = function (bytes) {
    return Integer.fromBuffer(bytes);
  };

  this._decodeVarintAsBigInt = function decodeVarintAsBigInt(bytes) {
    let result = bigInt0;
    if (bytes[0] <= 0x7f) {
      for (let i = 0; i < bytes.length; i++) {
        const b = BigInt(bytes[bytes.length - 1 - i]);
        result = result | (b << BigInt(i * 8));
      }
    } else {
      for (let i = 0; i < bytes.length; i++) {
        const b = BigInt(bytes[bytes.length - 1 - i]);
        result = result | ((~b & bigInt8BitsOn) << BigInt(i * 8));
      }
      result = ~result;
    }

    return result;
  };

  this.decodeVarint = this.encodingOptions.useBigIntAsVarint
    ? this._decodeVarintAsBigInt
    : this._decodeVarintAsInteger;

  this.decodeDecimal = function(bytes) {
    return BigDecimal.fromBuffer(bytes);
  };
  this.decodeTimestamp = function(bytes) {
    return new Date(this._decodeCqlLongAsLong(bytes).toNumber());
  };
  this.decodeDate = function (bytes) {
    return types.LocalDate.fromBuffer(bytes);
  };
  this.decodeTime = function (bytes) {
    return types.LocalTime.fromBuffer(bytes);
  };
  
  this.decodeList = function (bytes, subtype) {
    const totalItems = this.decodeCollectionLength(bytes, 0);
    let offset = this.collectionLengthSize;
    const list = new Array(totalItems);
    for (let i = 0; i < totalItems; i++) {
      
      const length = this.decodeCollectionLength(bytes, offset);
      offset += this.collectionLengthSize;
      
      list[i] = this.decode(bytes.slice(offset, offset+length), subtype);
      offset += length;
    }
    return list;
  };
  
  this.decodeSet = function (bytes, subtype) {
    const arr = this.decodeList(bytes, subtype);
    if (this.encodingOptions.set) {
      const setConstructor = this.encodingOptions.set;
      return new setConstructor(arr);
    }
    return arr;
  };
  
  this.decodeMap = function (bytes, subtypes) {
    let map;
    const totalItems = this.decodeCollectionLength(bytes, 0);
    let offset = this.collectionLengthSize;
    const self = this;
    function readValues(callback, thisArg) {
      for (let i = 0; i < totalItems; i++) {
        const keyLength = self.decodeCollectionLength(bytes, offset);
        offset += self.collectionLengthSize;
        const key = self.decode(bytes.slice(offset, offset + keyLength), subtypes[0]);
        offset += keyLength;
        const valueLength = self.decodeCollectionLength(bytes, offset);
        offset += self.collectionLengthSize;
        if (valueLength < 0) {
          callback.call(thisArg, key, null);
          continue;
        }
        const value = self.decode(bytes.slice(offset, offset + valueLength), subtypes[1]);
        offset += valueLength;
        callback.call(thisArg, key, value);
      }
    }
    if (this.encodingOptions.map) {
      const mapConstructor = this.encodingOptions.map;
      map = new mapConstructor();
      readValues(map.set, map);
    }
    else {
      map = {};
      readValues(function (key, value) {
        map[key] = value;
      });
    }
    return map;
  };
  this.decodeUuid = function (bytes) {
    return new types.Uuid(this.handleBuffer(bytes));
  };
  this.decodeTimeUuid = function (bytes) {
    return new types.TimeUuid(this.handleBuffer(bytes));
  };
  this.decodeInet = function (bytes) {
    return new types.InetAddress(this.handleBuffer(bytes));
  };
  
  this.decodeUdt = function (bytes, udtInfo) {
    const result = {};
    let offset = 0;
    for (let i = 0; i < udtInfo.fields.length && offset < bytes.length; i++) {
      
      const length = bytes.readInt32BE(offset);
      offset += 4;
      
      const field = udtInfo.fields[i];
      if (length < 0) {
        result[field.name] = null;
        continue;
      }
      result[field.name] = this.decode(bytes.slice(offset, offset+length), field.type);
      offset += length;
    }
    return result;
  };
  this.decodeTuple = function (bytes, tupleInfo) {
    const elements = new Array(tupleInfo.length);
    let offset = 0;
    for (let i = 0; i < tupleInfo.length; i++) {
      const length = bytes.readInt32BE(offset);
      offset += 4;
      if (length < 0) {
        elements[i] = null;
        continue;
      }
      elements[i] = this.decode(bytes.slice(offset, offset+length), tupleInfo[i]);
      offset += length;
    }
    return new types.Tuple(elements);
  };
  
  this.encodeFloat = function (value) {
    if (typeof value !== 'number') {
      throw new TypeError('Expected Number, obtained ' + util.inspect(value));
    }
    const buf = utils.allocBufferUnsafe(4);
    buf.writeFloatBE(value, 0);
    return buf;
  };
  this.encodeDouble = function (value) {
    if (typeof value !== 'number') {
      throw new TypeError('Expected Number, obtained ' + util.inspect(value));
    }
    const buf = utils.allocBufferUnsafe(8);
    buf.writeDoubleBE(value, 0);
    return buf;
  };
  
  this.encodeTimestamp = function (value) {
    const originalValue = value;
    if (typeof value === 'string') {
      value = new Date(value);
    }
    if (value instanceof Date) {
      
      value = value.getTime();
      if (isNaN(value)) {
        throw new TypeError('Invalid date: ' + originalValue);
      }
    }
    return this.encodeLong(value);
  };
  
  this.encodeDate = function (value) {
    const originalValue = value;
    try {
      if (typeof value === 'string') {
        value = types.LocalDate.fromString(value);
      }
      if (value instanceof Date) {
        value = types.LocalDate.fromDate(value);
      }
    }
    catch (err) {
      
      throw new TypeError('LocalDate could not be parsed ' + err);
    }
    if (!(value instanceof types.LocalDate)) {
      throw new TypeError('Expected Date/String/LocalDate, obtained ' + util.inspect(originalValue));
    }
    return value.toBuffer();
  };
  
  this.encodeTime = function (value) {
    const originalValue = value;
    try {
      if (typeof value === 'string') {
        value = types.LocalTime.fromString(value);
      }
    }
    catch (err) {
      
      throw new TypeError('LocalTime could not be parsed ' + err);
    }
    if (!(value instanceof types.LocalTime)) {
      throw new TypeError('Expected String/LocalTime, obtained ' + util.inspect(originalValue));
    }
    return value.toBuffer();
  };
  
  this.encodeUuid = function (value) {
    if (typeof value === 'string') {
      try {
        value = types.Uuid.fromString(value).getBuffer();
      }
      catch (err) {
        throw new TypeError(err.message);
      }
    } else if (value instanceof types.Uuid) {
      value = value.getBuffer();
    } else {
      throw new TypeError('Not a valid Uuid, expected Uuid/String/Buffer, obtained ' + util.inspect(value));
    }

    return value;
  };
  
  this.encodeInet = function (value) {
    if (typeof value === 'string') {
      value = types.InetAddress.fromString(value);
    }
    if (value instanceof types.InetAddress) {
      value = value.getBuffer();
    }
    if (!(value instanceof Buffer)) {
      throw new TypeError('Not a valid Inet, expected InetAddress/Buffer, obtained ' + util.inspect(value));
    }
    return value;
  };

  
  this._encodeBigIntFromLong = function (value) {
    if (typeof value === 'number') {
      value = Long.fromNumber(value);
    } else if (typeof value === 'string') {
      value = Long.fromString(value);
    }

    let buf = null;

    if (value instanceof Long) {
      buf = Long.toBuffer(value);
    } else if (value instanceof MutableLong) {
      buf = Long.toBuffer(value.toImmutable());
    }

    if (buf === null) {
      throw new TypeError('Not a valid bigint, expected Long/Number/String/Buffer, obtained ' + util.inspect(value));
    }

    return buf;
  };

  this._encodeBigIntFromBigInt = function (value) {
    
    if (typeof value !== 'bigint') {
      
      throw new TypeError('Not a valid BigInt value, obtained ' + util.inspect(value));
    }

    const buffer = utils.allocBufferUnsafe(8);
    buffer.writeUInt32BE(Number(value >> bigInt32) >>> 0, 0);
    buffer.writeUInt32BE(Number(value & bigInt32BitsOn), 4);
    return buffer;
  };

  this.encodeLong = this.encodingOptions.useBigIntAsLong
    ? this._encodeBigIntFromBigInt
    : this._encodeBigIntFromLong;

  
  this._encodeVarintFromInteger = function (value) {
    if (typeof value === 'number') {
      value = Integer.fromNumber(value);
    }
    if (typeof value === 'string') {
      value = Integer.fromString(value);
    }
    let buf = null;
    if (value instanceof Buffer) {
      buf = value;
    }
    if (value instanceof Integer) {
      buf = Integer.toBuffer(value);
    }
    if (buf === null) {
      throw new TypeError('Not a valid varint, expected Integer/Number/String/Buffer, obtained ' + util.inspect(value));
    }
    return buf;
  };

  this._encodeVarintFromBigInt = function (value) {
    
    if (typeof value !== 'bigint') {
      throw new TypeError('Not a valid varint, expected BigInt, obtained ' + util.inspect(value));
    }

    if (value === bigInt0) {
      return buffers.int8Zero;

    }
    else if (value === bigIntMinus1) {
      return buffers.int8MaxValue;
    }

    const parts = [];

    if (value > bigInt0){
      while (value !== bigInt0) {
        parts.unshift(Number(value & bigInt8BitsOn));
        value = value >> bigInt8;
      }

      if (parts[0] > 0x7f) {
        
        parts.unshift(0);
      }
    } else {
      while (value !== bigIntMinus1) {
        parts.unshift(Number(value & bigInt8BitsOn));
        value = value >> bigInt8;
      }

      if (parts[0] <= 0x7f) {
        
        parts.unshift(0xff);
      }
    }

    return utils.allocBufferFromArray(parts);
  };

  this.encodeVarint = this.encodingOptions.useBigIntAsVarint
    ? this._encodeVarintFromBigInt
    : this._encodeVarintFromInteger;

  
  this.encodeDecimal = function (value) {
    if (typeof value === 'number') {
      value = BigDecimal.fromNumber(value);
    } else if (typeof value === 'string') {
      value = BigDecimal.fromString(value);
    }

    let buf = null;

    if (value instanceof BigDecimal) {
      buf = BigDecimal.toBuffer(value);
    } else {
      throw new TypeError('Not a valid varint, expected BigDecimal/Number/String/Buffer, obtained ' + util.inspect(value));
    }

    return buf;
  };
  this.encodeString = function (value, encoding) {
    if (typeof value !== 'string') {
      throw new TypeError('Not a valid text value, expected String obtained ' + util.inspect(value));
    }
    return utils.allocBufferFromString(value, encoding);
  };
  this.encodeUtf8String = function (value) {
    return this.encodeString(value, 'utf8');
  };
  this.encodeAsciiString = function (value) {
    return this.encodeString(value, 'ascii');
  };
  this.encodeBlob = function (value) {
    if (!(value instanceof Buffer)) {
      throw new TypeError('Not a valid blob, expected Buffer obtained ' + util.inspect(value));
    }
    return value;
  };
  this.encodeCustom = function (value, name) {
    const handler = customEncoders[name];
    if (handler) {
      return handler.call(this, value);
    }
    throw new TypeError('No encoding handler found for type ' + name);
  };
  this.encodeDuration = function (value) {
    if (!(value instanceof types.Duration)) {
      throw new TypeError('Not a valid duration, expected Duration/Buffer obtained ' + util.inspect(value));
    }
    return value.toBuffer();
  };
  
  this.encodeBoolean = function (value) {
    return value ? buffers.int8One : buffers.int8Zero;
  };
  
  this.encodeInt = function (value) {
    if (isNaN(value)) {
      throw new TypeError('Expected Number, obtained ' + util.inspect(value));
    }
    const buf = utils.allocBufferUnsafe(4);
    buf.writeInt32BE(value, 0);
    return buf;
  };
  
  this.encodeSmallint = function (value) {
    if (isNaN(value)) {
      throw new TypeError('Expected Number, obtained ' + util.inspect(value));
    }
    const buf = utils.allocBufferUnsafe(2);
    buf.writeInt16BE(value, 0);
    return buf;
  };
  
  this.encodeTinyint = function (value) {
    if (isNaN(value)) {
      throw new TypeError('Expected Number, obtained ' + util.inspect(value));
    }
    const buf = utils.allocBufferUnsafe(1);
    buf.writeInt8(value, 0);
    return buf;
  };
  this.encodeList = function (value, subtype) {
    if (!util.isArray(value)) {
      throw new TypeError('Not a valid list value, expected Array obtained ' + util.inspect(value));
    }
    if (value.length === 0) {
      return null;
    }
    const parts = [];
    parts.push(this.getLengthBuffer(value));
    for (let i = 0;i < value.length;i++) {
      const val = value[i];
      if (val === null || typeof val === 'undefined' || val === types.unset) {
        throw new TypeError('A collection can\'t contain null or unset values');
      }
      const bytes = this.encode(val, subtype);
      
      parts.push(this.getLengthBuffer(bytes));
      
      parts.push(bytes);
    }
    return Buffer.concat(parts);
  };
  this.encodeSet = function (value, subtype) {
    if (this.encodingOptions.set && value instanceof this.encodingOptions.set) {
      const arr = [];
      value.forEach(function (x) {
        arr.push(x);
      });
      return this.encodeList(arr, subtype);
    }
    return this.encodeList(value, subtype);
  };
  
  this.encodeMap = function (value, subtypes) {
    const parts = [];
    let propCounter = 0;
    let keySubtype = null;
    let valueSubtype = null;
    const self = this;
    if (subtypes) {
      keySubtype = subtypes[0];
      valueSubtype = subtypes[1];
    }
    function addItem(val, key) {
      if (key === null || typeof key === 'undefined' || key === types.unset) {
        throw new TypeError('A map can\'t contain null or unset keys');
      }
      if (val === null || typeof val === 'undefined' || val === types.unset) {
        throw new TypeError('A map can\'t contain null or unset values');
      }
      const keyBuffer = self.encode(key, keySubtype);
      
      parts.push(self.getLengthBuffer(keyBuffer));
      
      parts.push(keyBuffer);
      
      const valueBuffer = self.encode(val, valueSubtype);
      
      parts.push(self.getLengthBuffer(valueBuffer));
      
      if (valueBuffer !== null) {
        parts.push(valueBuffer);
      }
      propCounter++;
    }
    if (this.encodingOptions.map && value instanceof this.encodingOptions.map) {
      
      value.forEach(addItem);
    }
    else {
      
      for (const key in value) {
        if (!value.hasOwnProperty(key)) {
          continue;
        }
        const val = value[key];
        addItem(val, key);
      }
    }

    parts.unshift(this.getLengthBuffer(propCounter));
    return Buffer.concat(parts);
  };
  this.encodeUdt = function (value, udtInfo) {
    const parts = [];
    let totalLength = 0;
    for (let i = 0; i < udtInfo.fields.length; i++) {
      const field = udtInfo.fields[i];
      const item = this.encode(value[field.name], field.type);
      if (!item) {
        parts.push(nullValueBuffer);
        totalLength += 4;
        continue;
      }
      if (item === types.unset) {
        parts.push(unsetValueBuffer);
        totalLength += 4;
        continue;
      }
      const lengthBuffer = utils.allocBufferUnsafe(4);
      lengthBuffer.writeInt32BE(item.length, 0);
      parts.push(lengthBuffer);
      parts.push(item);
      totalLength += item.length + 4;
    }
    return Buffer.concat(parts, totalLength);
  };
  this.encodeTuple = function (value, tupleInfo) {
    const parts = [];
    let totalLength = 0;
    for (let i = 0; i < tupleInfo.length; i++) {
      const type = tupleInfo[i];
      const item = this.encode(value.get(i), type);
      if (!item) {
        parts.push(nullValueBuffer);
        totalLength += 4;
        continue;
      }
      if (item === types.unset) {
        parts.push(unsetValueBuffer);
        totalLength += 4;
        continue;
      }
      const lengthBuffer = utils.allocBufferUnsafe(4);
      lengthBuffer.writeInt32BE(item.length, 0);
      parts.push(lengthBuffer);
      parts.push(item);
      totalLength += item.length + 4;
    }
    return Buffer.concat(parts, totalLength);
  };

  
  this.setRoutingKeyFromUser = function (params, execOptions, keys) {
    let totalLength = 0;
    const userRoutingKey = execOptions.getRoutingKey();
    if (util.isArray(userRoutingKey)) {
      if (userRoutingKey.length === 1) {
        execOptions.setRoutingKey(userRoutingKey[0]);
        return;
      }

      
      totalLength = 0;
      for (let i = 0; i < userRoutingKey.length; i++) {
        const item = userRoutingKey[i];
        if (!item) {
          
          execOptions.setRoutingKey(null);
          return;
        }
        totalLength += item.length + 3;
      }

      execOptions.setRoutingKey(concatRoutingKey(userRoutingKey, totalLength));
      return;
    }
    
    if (userRoutingKey) {
      if (userRoutingKey instanceof Buffer || userRoutingKey instanceof token.Token
        || userRoutingKey instanceof token.TokenRange) {
        return;
      }

      throw new TypeError(`Unexpected routingKey '${util.inspect(userRoutingKey)}' provided. ` +
        `Expected Buffer, Array<Buffer>, Token, or TokenRange.`);
    }

    
    if (!params || params.length === 0) {
      return;
    }

    let routingIndexes = execOptions.getRoutingIndexes();
    if (execOptions.getRoutingNames()) {
      routingIndexes = execOptions.getRoutingNames().map(k => keys[k]);
    }
    if (!routingIndexes) {
      return;
    }

    const parts = [];
    const hints = execOptions.getHints() || utils.emptyArray;

    const encodeParam = !keys ?
      (i => this.encode(params[i], hints[i])) :
      (i => this.encode(params[i].value, hints[i]));

    try {
      totalLength = this._encodeRoutingKeyParts(parts, routingIndexes, encodeParam);
    } catch (e) {
      
      
    }

    if (totalLength === 0) {
      return;
    }

    execOptions.setRoutingKey(concatRoutingKey(parts, totalLength));
  };

  
  this.setRoutingKeyFromMeta = function (meta, params, execOptions) {
    const routingIndexes = execOptions.getRoutingIndexes();
    if (!routingIndexes) {
      return;
    }
    const parts = new Array(routingIndexes.length);
    const encodeParam = i => {
      const columnInfo = meta.columns[i];
      return this.encode(params[i], columnInfo ? columnInfo.type : null);
    };

    let totalLength = 0;

    try {
      totalLength = this._encodeRoutingKeyParts(parts, routingIndexes, encodeParam);
    } catch (e) {
      
      
    }

    if (totalLength === 0) {
      return;
    }

    execOptions.setRoutingKey(concatRoutingKey(parts, totalLength));
  };

  
  this._encodeRoutingKeyParts = function (parts, routingIndexes, encodeParam) {
    let totalLength = 0;
    for (let i = 0; i < routingIndexes.length; i++) {
      const paramIndex = routingIndexes[i];
      if (paramIndex === undefined) {
        
        return 0;
      }

      const item = encodeParam(paramIndex);
      if (item === null || item === undefined || item === types.unset) {
        
        
        return 0;
      }

      
      totalLength += item.length + 3;
      parts[i] = item;
    }
    return totalLength;
  };

  
  this.parseTypeName = function (keyspace, typeName, startIndex, length, udtResolver, callback) {
    startIndex = startIndex || 0;
    if (!length) {
      length = typeName.length;
    }
    const dataType = {
      code: 0,
      info: null,
      options: {
        frozen: false
      }
    };
    let innerTypes;
    if (typeName.indexOf("'", startIndex) === startIndex) {
      
      dataType.info = typeName.substr(startIndex+1, length-2);
      return callback(null, dataType);
    }
    if (!length) {
      length = typeName.length;
    }
    if (typeName.indexOf(cqlNames.frozen, startIndex) === startIndex) {
      
      startIndex += cqlNames.frozen.length + 1;
      length -= cqlNames.frozen.length + 2;
      dataType.options.frozen = true;
    }
    if (typeName.indexOf(cqlNames.list, startIndex) === startIndex) {
      
      startIndex += cqlNames.list.length + 1;
      length -= cqlNames.list.length + 2;
      innerTypes = parseParams(typeName, startIndex, length, '<', '>');
      if (innerTypes.length !== 1) {
        return callback(new TypeError('Not a valid type ' + typeName));
      }
      dataType.code = dataTypes.list;
      return this.parseTypeName(keyspace, innerTypes[0], 0, null, udtResolver, function (err, childType) {
        if (err) {
          return callback(err);
        }
        dataType.info = childType;
        callback(null, dataType);
      });
    }
    if (typeName.indexOf(cqlNames.set, startIndex) === startIndex) {
      
      startIndex += cqlNames.set.length + 1;
      length -= cqlNames.set.length + 2;
      innerTypes = parseParams(typeName, startIndex, length, '<', '>');
      if (innerTypes.length !== 1) {
        return callback(new TypeError('Not a valid type ' + typeName));
      }
      dataType.code = dataTypes.set;
      return this.parseTypeName(keyspace, innerTypes[0], 0, null, udtResolver, function (err, childType) {
        if (err) {
          return callback(err);
        }
        dataType.info = childType;
        callback(null, dataType);
      });
    }
    if (typeName.indexOf(cqlNames.map, startIndex) === startIndex) {
      
      startIndex += cqlNames.map.length + 1;
      length -= cqlNames.map.length + 2;
      innerTypes = parseParams(typeName, startIndex, length, '<', '>');
      
      if (innerTypes.length !== 2) {
        return callback(new TypeError('Not a valid type ' + typeName));
      }
      dataType.code = dataTypes.map;
      return this._parseChildTypes(keyspace, dataType, innerTypes, udtResolver, callback);
    }
    if (typeName.indexOf(cqlNames.tuple, startIndex) === startIndex) {
      
      startIndex += cqlNames.tuple.length + 1;
      length -= cqlNames.tuple.length + 2;
      innerTypes = parseParams(typeName, startIndex, length, '<', '>');
      if (innerTypes.length < 1) {
        throw new TypeError('Not a valid type ' + typeName);
      }
      dataType.code = dataTypes.tuple;
      return this._parseChildTypes(keyspace, dataType, innerTypes, udtResolver, callback);
    }
    const quoted = typeName.indexOf('"', startIndex) === startIndex;
    if (quoted) {
      
      startIndex++;
      length -= 2;
    }
    
    if (startIndex > 0) {
      typeName = typeName.substr(startIndex, length);
    }
    
    if (quoted) {
      typeName = typeName.replace('""', '"');
    }
    const typeCode = dataTypes[typeName];
    if (typeof typeCode === 'number') {
      dataType.code = typeCode;
      return callback(null, dataType);
    }
    if (typeName === cqlNames.duration) {
      dataType.info = durationTypeName;
      return callback(null, dataType);
    }
    if (typeName === cqlNames.empty) {
      
      dataType.info = 'empty';
      return callback(null, dataType);
    }
    udtResolver(keyspace, typeName, function (err, udtInfo) {
      if (err) {
        return callback(err);
      }
      if (udtInfo) {
        dataType.code = dataTypes.udt;
        dataType.info = udtInfo;
        return callback(null, dataType);
      }
      callback(new TypeError('Not a valid type "' + typeName + '"'));
    });
  };
  
  this._parseChildTypes = function (keyspace, dataType, typeNames, udtResolver, callback) {
    const self = this;
    utils.mapSeries(typeNames, function (name, next) {
      self.parseTypeName(keyspace, name.trim(), 0, null, udtResolver, next);
    }, function (err, childTypes) {
      if (err) {
        return callback(err);
      }
      dataType.info = childTypes;
      callback(null, dataType);
    });
  };

  
  this.parseFqTypeName = function (typeName, startIndex, length) {
    const dataType = {
      code: 0,
      info: null,
      options: {
        reversed: false,
        frozen: false
      }
    };
    startIndex = startIndex || 0;
    let innerTypes;
    if (!length) {
      length = typeName.length;
    }
    if (length > complexTypeNames.reversed.length && typeName.indexOf(complexTypeNames.reversed) === startIndex) {
      
      startIndex += complexTypeNames.reversed.length + 1;
      length -= complexTypeNames.reversed.length + 2;
      dataType.options.reversed = true;
    }
    if (length > complexTypeNames.frozen.length &&
        typeName.indexOf(complexTypeNames.frozen, startIndex) === startIndex) {
      
      startIndex += complexTypeNames.frozen.length + 1;
      length -= complexTypeNames.frozen.length + 2;
      dataType.options.frozen = true;
    }
    if (typeName === complexTypeNames.empty) {
      
      dataType.info = 'empty';
      return dataType;
    }
    
    if (length <= singleFqTypeNamesLength) {
      if (startIndex > 0) {
        typeName = typeName.substr(startIndex, length);
      }
      const typeCode = singleTypeNames[typeName];
      if (typeof typeCode === 'number') {
        dataType.code = typeCode;
        return dataType;
      }
      throw new TypeError('Not a valid type "' + typeName + '"');
    }
    if (typeName.indexOf(complexTypeNames.list, startIndex) === startIndex) {
      
      
      
      startIndex += complexTypeNames.list.length + 1;
      length -= complexTypeNames.list.length + 2;
      innerTypes = parseParams(typeName, startIndex, length);
      if (innerTypes.length !== 1) {
        throw new TypeError('Not a valid type ' + typeName);
      }
      dataType.code = dataTypes.list;
      dataType.info = this.parseFqTypeName(innerTypes[0]);
      return dataType;
    }
    if (typeName.indexOf(complexTypeNames.set, startIndex) === startIndex) {
      
      
      
      startIndex += complexTypeNames.set.length + 1;
      length -= complexTypeNames.set.length + 2;
      innerTypes = parseParams(typeName, startIndex, length);
      if (innerTypes.length !== 1)
      {
        throw new TypeError('Not a valid type ' + typeName);
      }
      dataType.code = dataTypes.set;
      dataType.info = this.parseFqTypeName(innerTypes[0]);
      return dataType;
    }
    if (typeName.indexOf(complexTypeNames.map, startIndex) === startIndex) {
      
      
      startIndex += complexTypeNames.map.length + 1;
      length -= complexTypeNames.map.length + 2;
      innerTypes = parseParams(typeName, startIndex, length);
      
      if (innerTypes.length !== 2) {
        throw new TypeError('Not a valid type ' + typeName);
      }
      dataType.code = dataTypes.map;
      dataType.info = [this.parseFqTypeName(innerTypes[0]), this.parseFqTypeName(innerTypes[1])];
      return dataType;
    }
    if (typeName.indexOf(complexTypeNames.udt, startIndex) === startIndex) {
      
      startIndex += complexTypeNames.udt.length + 1;
      length -= complexTypeNames.udt.length + 2;
      return this._parseUdtName(typeName, startIndex, length);
    }
    if (typeName.indexOf(complexTypeNames.tuple, startIndex) === startIndex) {
      
      startIndex += complexTypeNames.tuple.length + 1;
      length -= complexTypeNames.tuple.length + 2;
      innerTypes = parseParams(typeName, startIndex, length);
      if (innerTypes.length < 1) {
        throw new TypeError('Not a valid type ' + typeName);
      }
      dataType.code = dataTypes.tuple;
      dataType.info = innerTypes.map(x => this.parseFqTypeName(x));
      return dataType;
    }

    
    dataType.info = typeName.substr(startIndex, length);
    return dataType;
  };
  
  this.parseKeyTypes = function (typesString) {
    let i = 0;
    let length = typesString.length;
    const isComposite = typesString.indexOf(complexTypeNames.composite) === 0;
    if (isComposite) {
      i = complexTypeNames.composite.length + 1;
      length--;
    }
    const types = [];
    let startIndex = i;
    let nested = 0;
    let inCollectionType = false;
    let hasCollections = false;
    
    while (++i < length) {
      switch (typesString[i]) {
        case ',':
          if (nested > 0) {
            break;
          }
          if (inCollectionType) {
            
            startIndex = typesString.indexOf(':', startIndex) + 1;
          }
          types.push(typesString.substring(startIndex, i));
          startIndex = i + 1;
          break;
        case '(':
          if (nested === 0 && typesString.indexOf(complexTypeNames.collection, startIndex) === startIndex) {
            inCollectionType = true;
            hasCollections = true;
            
            i++;
            startIndex = i;
            break;
          }
          nested++;
          break;
        case ')':
          if (inCollectionType && nested === 0){
            types.push(typesString.substring(typesString.indexOf(':', startIndex) + 1, i));
            startIndex = i + 1;
            break;
          }
          nested--;
          break;
      }
    }
    if (startIndex < length) {
      types.push(typesString.substring(startIndex, length));
    }
    return {
      types: types.map(name => this.parseFqTypeName(name)),
      hasCollections: hasCollections,
      isComposite: isComposite
    };
  };
  this._parseUdtName = function (typeName, startIndex, length) {
    const udtParams = parseParams(typeName, startIndex, length);
    if (udtParams.length < 2) {
      
      throw new TypeError('Not a valid type ' + typeName);
    }
    const dataType = {
      code: dataTypes.udt,
      info: null
    };
    const udtInfo = {
      keyspace: udtParams[0],
      name: utils.allocBufferFromString(udtParams[1], 'hex').toString(),
      fields: []
    };
    for (let i = 2; i < udtParams.length; i++) {
      const p = udtParams[i];
      const separatorIndex = p.indexOf(':');
      const fieldType = this.parseFqTypeName(p, separatorIndex + 1, p.length - (separatorIndex + 1));
      udtInfo.fields.push({
        name: utils.allocBufferFromString(p.substr(0, separatorIndex), 'hex').toString(),
        type: fieldType
      });
    }
    dataType.info = udtInfo;
    return dataType;
  };

  customDecoders[durationTypeName] = this.decodeDuration;
  customEncoders[durationTypeName] = this.encodeDuration;
}
function defineInstanceMembers ( ) { /**
   * Sets the protocol version and the encoding/decoding methods depending on the protocol version
   * @param {Number} value
   * @ignore
   * @internal
   */ this . setProtocolVersion = function ( value ) { this . protocolVersion = value ; //Set the collection serialization based on the protocol version this . decodeCollectionLength = decodeCollectionLengthV3 ; this . getLengthBuffer = getLengthBufferV3 ; this . collectionLengthSize = 4 ; if ( ! types . protocolVersion . uses4BytesCollectionLength ( this . protocolVersion ) ) { this . decodeCollectionLength = decodeCollectionLengthV2 ; this . getLengthBuffer = getLengthBufferV2 ; this . collectionLengthSize = 2 ; } } ; const customDecoders = { } ; const customEncoders = { } ; // Decoding methods this . decodeBlob = function ( bytes ) { return this . handleBuffer ( bytes ) ; } ; this . decodeCustom = function ( bytes , typeName ) { const handler = customDecoders [ typeName ] ; if ( handler ) { return handler . call ( this , bytes ) ; } return this . handleBuffer ( bytes ) ; } ; this . decodeDuration = function ( bytes ) { return types . Duration . fromBuffer ( bytes ) ; } ; this . decodeUtf8String = function ( bytes ) { return bytes . toString ( 'utf8' ) ; } ; this . decodeAsciiString = function ( bytes ) { return bytes . toString ( 'ascii' ) ; } ; this . decodeBoolean = function ( bytes ) { return ! ! bytes . readUInt8 ( 0 ) ; } ; this . decodeDouble = function ( bytes ) { return bytes . readDoubleBE ( 0 ) ; } ; this . decodeFloat = function ( bytes ) { return bytes . readFloatBE ( 0 ) ; } ; this . decodeInt = function ( bytes ) { return bytes . readInt32BE ( 0 ) ; } ; this . decodeSmallint = function ( bytes ) { return bytes . readInt16BE ( 0 ) ; } ; this . decodeTinyint = function ( bytes ) { return bytes . readInt8 ( 0 ) ; } ; this . _decodeCqlLongAsLong = function ( bytes ) { return Long . fromBuffer ( bytes ) ; } ; this . _decodeCqlLongAsBigInt = function ( bytes ) { return BigInt . asIntN ( 64 , ( BigInt ( bytes . readUInt32BE ( 0 ) ) << bigInt32 ) | BigInt ( bytes . readUInt32BE ( 4 ) ) ) ; } ; this . decodeLong = this . encodingOptions . useBigIntAsLong ? this . _decodeCqlLongAsBigInt : this . _decodeCqlLongAsLong ; this . _decodeVarintAsInteger = function ( bytes ) { return Integer . fromBuffer ( bytes ) ; } ; this . _decodeVarintAsBigInt = function decodeVarintAsBigInt ( bytes ) { let result = bigInt0 ; if ( bytes [ 0 ] <= 0x7f ) { for ( let i = 0 ; i < bytes . length ; i ++ ) { const b = BigInt ( bytes [ bytes . length - 1 - i ] ) ; result = result | ( b << BigInt ( i * 8 ) ) ; } } else { for ( let i = 0 ; i < bytes . length ; i ++ ) { const b = BigInt ( bytes [ bytes . length - 1 - i ] ) ; result = result | ( ( ~ b & bigInt8BitsOn ) << BigInt ( i * 8 ) ) ; } result = ~ result ; } return result ; } ; this . decodeVarint = this . encodingOptions . useBigIntAsVarint ? this . _decodeVarintAsBigInt : this . _decodeVarintAsInteger ; this . decodeDecimal = function ( bytes ) { return BigDecimal . fromBuffer ( bytes ) ; } ; this . decodeTimestamp = function ( bytes ) { return new Date ( this . _decodeCqlLongAsLong ( bytes ) . toNumber ( ) ) ; } ; this . decodeDate = function ( bytes ) { return types . LocalDate . fromBuffer ( bytes ) ; } ; this . decodeTime = function ( bytes ) { return types . LocalTime . fromBuffer ( bytes ) ; } ; /*
   * Reads a list from bytes
   */ this . decodeList = function ( bytes , subtype ) { const totalItems = this . decodeCollectionLength ( bytes , 0 ) ; let offset = this . collectionLengthSize ; const list = new Array ( totalItems ) ; for ( let i = 0 ; i < totalItems ; i ++ ) { //bytes length of the item const length = this . decodeCollectionLength ( bytes , offset ) ; offset += this . collectionLengthSize ; //slice it list [ i ] = this . decode ( bytes . slice ( offset , offset + length ) , subtype ) ; offset += length ; } return list ; } ; /*
   * Reads a Set from bytes
   */ this . decodeSet = function ( bytes , subtype ) { const arr = this . decodeList ( bytes , subtype ) ; if ( this . encodingOptions . set ) { const setConstructor = this . encodingOptions . set ; return new setConstructor ( arr ) ; } return arr ; } ; /*
   * Reads a map (key / value) from bytes
   */ this . decodeMap = function ( bytes , subtypes ) { let map ; const totalItems = this . decodeCollectionLength ( bytes , 0 ) ; let offset = this . collectionLengthSize ; const self = this ; function readValues ( callback , thisArg ) { for ( let i = 0 ; i < totalItems ; i ++ ) { const keyLength = self . decodeCollectionLength ( bytes , offset ) ; offset += self . collectionLengthSize ; const key = self . decode ( bytes . slice ( offset , offset + keyLength ) , subtypes [ 0 ] ) ; offset += keyLength ; const valueLength = self . decodeCollectionLength ( bytes , offset ) ; offset += self . collectionLengthSize ; if ( valueLength < 0 ) { callback . call ( thisArg , key , null ) ; continue ; } const value = self . decode ( bytes . slice ( offset , offset + valueLength ) , subtypes [ 1 ] ) ; offset += valueLength ; callback . call ( thisArg , key , value ) ; } } if ( this . encodingOptions . map ) { const mapConstructor = this . encodingOptions . map ; map = new mapConstructor ( ) ; readValues ( map . set , map ) ; } else { map = { } ; readValues ( function ( key , value ) { map [ key ] = value ; } ) ; } return map ; } ; this . decodeUuid = function ( bytes ) { return new types . Uuid ( this . handleBuffer ( bytes ) ) ; } ; this . decodeTimeUuid = function ( bytes ) { return new types . TimeUuid ( this . handleBuffer ( bytes ) ) ; } ; this . decodeInet = function ( bytes ) { return new types . InetAddress ( this . handleBuffer ( bytes ) ) ; } ; /**
   * Decodes a user defined type into an object
   * @param {Buffer} bytes
   * @param {{fields: Array}} udtInfo
   * @private
   */ this . decodeUdt = function ( bytes , udtInfo ) { const result = { } ; let offset = 0 ; for ( let i = 0 ; i < udtInfo . fields . length && offset < bytes . length ; i ++ ) { //bytes length of the field value const length = bytes . readInt32BE ( offset ) ; offset += 4 ; //slice it const field = udtInfo . fields [ i ] ; if ( length < 0 ) { result [ field . name ] = null ; continue ; } result [ field . name ] = this . decode ( bytes . slice ( offset , offset + length ) , field . type ) ; offset += length ; } return result ; } ; this . decodeTuple = function ( bytes , tupleInfo ) { const elements = new Array ( tupleInfo . length ) ; let offset = 0 ; for ( let i = 0 ; i < tupleInfo . length ; i ++ ) { const length = bytes . readInt32BE ( offset ) ; offset += 4 ; if ( length < 0 ) { elements [ i ] = null ; continue ; } elements [ i ] = this . decode ( bytes . slice ( offset , offset + length ) , tupleInfo [ i ] ) ; offset += length ; } return new types . Tuple ( elements ) ; } ; //Encoding methods this . encodeFloat = function ( value ) { if ( typeof value !== 'number' ) { throw new TypeError ( 'Expected Number, obtained ' + util . inspect ( value ) ) ; } const buf = utils . allocBufferUnsafe ( 4 ) ; buf . writeFloatBE ( value , 0 ) ; return buf ; } ; this . encodeDouble = function ( value ) { if ( typeof value !== 'number' ) { throw new TypeError ( 'Expected Number, obtained ' + util . inspect ( value ) ) ; } const buf = utils . allocBufferUnsafe ( 8 ) ; buf . writeDoubleBE ( value , 0 ) ; return buf ; } ; /**
   * @param {Date|String|Long|Number} value
   * @private
   */ this . encodeTimestamp = function ( value ) { const originalValue = value ; if ( typeof value === 'string' ) { value = new Date ( value ) ; } if ( value instanceof Date ) { //milliseconds since epoch value = value . getTime ( ) ; if ( isNaN ( value ) ) { throw new TypeError ( 'Invalid date: ' + originalValue ) ; } } return this . encodeLong ( value ) ; } ; /**
   * @param {Date|String|LocalDate} value
   * @returns {Buffer}
   * @throws {TypeError}
   * @private
   */ this . encodeDate = function ( value ) { const originalValue = value ; try { if ( typeof value === 'string' ) { value = types . LocalDate . fromString ( value ) ; } if ( value instanceof Date ) { value = types . LocalDate . fromDate ( value ) ; } } catch ( err ) { //Wrap into a TypeError throw new TypeError ( 'LocalDate could not be parsed ' + err ) ; } if ( ! ( value instanceof types . LocalDate ) ) { throw new TypeError ( 'Expected Date/String/LocalDate, obtained ' + util . inspect ( originalValue ) ) ; } return value . toBuffer ( ) ; } ; /**
   * @param {String|LocalDate} value
   * @returns {Buffer}
   * @throws {TypeError}
   * @private
   */ this . encodeTime = function ( value ) { const originalValue = value ; try { if ( typeof value === 'string' ) { value = types . LocalTime . fromString ( value ) ; } } catch ( err ) { //Wrap into a TypeError throw new TypeError ( 'LocalTime could not be parsed ' + err ) ; } if ( ! ( value instanceof types . LocalTime ) ) { throw new TypeError ( 'Expected String/LocalTime, obtained ' + util . inspect ( originalValue ) ) ; } return value . toBuffer ( ) ; } ; /**
   * @param {Uuid|String|Buffer} value
   * @private
   */ this . encodeUuid = function ( value ) { if ( typeof value === 'string' ) { try { value = types . Uuid . fromString ( value ) . getBuffer ( ) ; } catch ( err ) { throw new TypeError ( err . message ) ; } } else if ( value instanceof types . Uuid ) { value = value . getBuffer ( ) ; } else { throw new TypeError ( 'Not a valid Uuid, expected Uuid/String/Buffer, obtained ' + util . inspect ( value ) ) ; } return value ; } ; /**
   * @param {String|InetAddress|Buffer} value
   * @returns {Buffer}
   * @private
   */ this . encodeInet = function ( value ) { if ( typeof value === 'string' ) { value = types . InetAddress . fromString ( value ) ; } if ( value instanceof types . InetAddress ) { value = value . getBuffer ( ) ; } if ( ! ( value instanceof Buffer ) ) { throw new TypeError ( 'Not a valid Inet, expected InetAddress/Buffer, obtained ' + util . inspect ( value ) ) ; } return value ; } ; /**
   * @param {Long|Buffer|String|Number} value
   * @private
   */ this . _encodeBigIntFromLong = function ( value ) { if ( typeof value === 'number' ) { value = Long . fromNumber ( value ) ; } else if ( typeof value === 'string' ) { value = Long . fromString ( value ) ; } let buf = null ; if ( value instanceof Long ) { buf = Long . toBuffer ( value ) ; } else if ( value instanceof MutableLong ) { buf = Long . toBuffer ( value . toImmutable ( ) ) ; } if ( buf === null ) { throw new TypeError ( 'Not a valid bigint, expected Long/Number/String/Buffer, obtained ' + util . inspect ( value ) ) ; } return buf ; } ; this . _encodeBigIntFromBigInt = function ( value ) { // eslint-disable-next-line valid-typeof if ( typeof value !== 'bigint' ) { // Only BigInt values are supported throw new TypeError ( 'Not a valid BigInt value, obtained ' + util . inspect ( value ) ) ; } const buffer = utils . allocBufferUnsafe ( 8 ) ; buffer . writeUInt32BE ( Number ( value >> bigInt32 ) >>> 0 , 0 ) ; buffer . writeUInt32BE ( Number ( value & bigInt32BitsOn ) , 4 ) ; return buffer ; } ; this . encodeLong = this . encodingOptions . useBigIntAsLong ? this . _encodeBigIntFromBigInt : this . _encodeBigIntFromLong ; /**
   * @param {Integer|Buffer|String|Number} value
   * @returns {Buffer}
   * @private
   */ this . _encodeVarintFromInteger = function ( value ) { if ( typeof value === 'number' ) { value = Integer . fromNumber ( value ) ; } if ( typeof value === 'string' ) { value = Integer . fromString ( value ) ; } let buf = null ; if ( value instanceof Buffer ) { buf = value ; } if ( value instanceof Integer ) { buf = Integer . toBuffer ( value ) ; } if ( buf === null ) { throw new TypeError ( 'Not a valid varint, expected Integer/Number/String/Buffer, obtained ' + util . inspect ( value ) ) ; } return buf ; } ; this . _encodeVarintFromBigInt = function ( value ) { // eslint-disable-next-line valid-typeof if ( typeof value !== 'bigint' ) { throw new TypeError ( 'Not a valid varint, expected BigInt, obtained ' + util . inspect ( value ) ) ; } if ( value === bigInt0 ) { return buffers . int8Zero ; } else if ( value === bigIntMinus1 ) { return buffers . int8MaxValue ; } const parts = [ ] ; if ( value > bigInt0 ) { while ( value !== bigInt0 ) { parts . unshift ( Number ( value & bigInt8BitsOn ) ) ; value = value >> bigInt8 ; } if ( parts [ 0 ] > 0x7f ) { // Positive value needs a padding parts . unshift ( 0 ) ; } } else { while ( value !== bigIntMinus1 ) { parts . unshift ( Number ( value & bigInt8BitsOn ) ) ; value = value >> bigInt8 ; } if ( parts [ 0 ] <= 0x7f ) { // Negative value needs a padding parts . unshift ( 0xff ) ; } } return utils . allocBufferFromArray ( parts ) ; } ; this . encodeVarint = this . encodingOptions . useBigIntAsVarint ? this . _encodeVarintFromBigInt : this . _encodeVarintFromInteger ; /**
   * @param {BigDecimal|Buffer|String|Number} value
   * @returns {Buffer}
   * @private
   */ this . encodeDecimal = function ( value ) { if ( typeof value === 'number' ) { value = BigDecimal . fromNumber ( value ) ; } else if ( typeof value === 'string' ) { value = BigDecimal . fromString ( value ) ; } let buf = null ; if ( value instanceof BigDecimal ) { buf = BigDecimal . toBuffer ( value ) ; } else { throw new TypeError ( 'Not a valid varint, expected BigDecimal/Number/String/Buffer, obtained ' + util . inspect ( value ) ) ; } return buf ; } ; this . encodeString = function ( value , encoding ) { if ( typeof value !== 'string' ) { throw new TypeError ( 'Not a valid text value, expected String obtained ' + util . inspect ( value ) ) ; } return utils . allocBufferFromString ( value , encoding ) ; } ; this . encodeUtf8String = function ( value ) { return this . encodeString ( value , 'utf8' ) ; } ; this . encodeAsciiString = function ( value ) { return this . encodeString ( value , 'ascii' ) ; } ; this . encodeBlob = function ( value ) { if ( ! ( value instanceof Buffer ) ) { throw new TypeError ( 'Not a valid blob, expected Buffer obtained ' + util . inspect ( value ) ) ; } return value ; } ; this . encodeCustom = function ( value , name ) { const handler = customEncoders [ name ] ; if ( handler ) { return handler . call ( this , value ) ; } throw new TypeError ( 'No encoding handler found for type ' + name ) ; } ; this . encodeDuration = function ( value ) { if ( ! ( value instanceof types . Duration ) ) { throw new TypeError ( 'Not a valid duration, expected Duration/Buffer obtained ' + util . inspect ( value ) ) ; } return value . toBuffer ( ) ; } ; /**
   * @param {Boolean} value
   * @returns {Buffer}
   * @private
   */ this . encodeBoolean = function ( value ) { return value ? buffers . int8One : buffers . int8Zero ; } ; /**
   * @param {Number|String} value
   * @private
   */ this . encodeInt = function ( value ) { if ( isNaN ( value ) ) { throw new TypeError ( 'Expected Number, obtained ' + util . inspect ( value ) ) ; } const buf = utils . allocBufferUnsafe ( 4 ) ; buf . writeInt32BE ( value , 0 ) ; return buf ; } ; /**
   * @param {Number|String} value
   * @private
   */ this . encodeSmallint = function ( value ) { if ( isNaN ( value ) ) { throw new TypeError ( 'Expected Number, obtained ' + util . inspect ( value ) ) ; } const buf = utils . allocBufferUnsafe ( 2 ) ; buf . writeInt16BE ( value , 0 ) ; return buf ; } ; /**
   * @param {Number|String} value
   * @private
   */ this . encodeTinyint = function ( value ) { if ( isNaN ( value ) ) { throw new TypeError ( 'Expected Number, obtained ' + util . inspect ( value ) ) ; } const buf = utils . allocBufferUnsafe ( 1 ) ; buf . writeInt8 ( value , 0 ) ; return buf ; } ; this . encodeList = function ( value , subtype ) { if ( ! util . isArray ( value ) ) { throw new TypeError ( 'Not a valid list value, expected Array obtained ' + util . inspect ( value ) ) ; } if ( value . length === 0 ) { return null ; } const parts = [ ] ; parts . push ( this . getLengthBuffer ( value ) ) ; for ( let i = 0 ; i < value . length ; i ++ ) { const val = value [ i ] ; if ( val === null || typeof val === 'undefined' || val === types . unset ) { throw new TypeError ( 'A collection can\'t contain null or unset values' ) ; } const bytes = this . encode ( val , subtype ) ; //include item byte length parts . push ( this . getLengthBuffer ( bytes ) ) ; //include item parts . push ( bytes ) ; } return Buffer . concat ( parts ) ; } ; this . encodeSet = function ( value , subtype ) { if ( this . encodingOptions . set && value instanceof this . encodingOptions . set ) { const arr = [ ] ; value . forEach ( function ( x ) { arr . push ( x ) ; } ) ; return this . encodeList ( arr , subtype ) ; } return this . encodeList ( value , subtype ) ; } ; /**
   * Serializes a map into a Buffer
   * @param value
   * @param {Array} [subtypes]
   * @returns {Buffer}
   * @private
   */ this . encodeMap = function ( value , subtypes ) { const parts = [ ] ; let propCounter = 0 ; let keySubtype = null ; let valueSubtype = null ; const self = this ; if ( subtypes ) { keySubtype = subtypes [ 0 ] ; valueSubtype = subtypes [ 1 ] ; } function addItem ( val , key ) { if ( key === null || typeof key === 'undefined' || key === types . unset ) { throw new TypeError ( 'A map can\'t contain null or unset keys' ) ; } if ( val === null || typeof val === 'undefined' || val === types . unset ) { throw new TypeError ( 'A map can\'t contain null or unset values' ) ; } const keyBuffer = self . encode ( key , keySubtype ) ; //include item byte length parts . push ( self . getLengthBuffer ( keyBuffer ) ) ; //include item parts . push ( keyBuffer ) ; //value const valueBuffer = self . encode ( val , valueSubtype ) ; //include item byte length parts . push ( self . getLengthBuffer ( valueBuffer ) ) ; //include item if ( valueBuffer !== null ) { parts . push ( valueBuffer ) ; } propCounter ++ ; } if ( this . encodingOptions . map && value instanceof this . encodingOptions . map ) { //Use Map#forEach() method to iterate value . forEach ( addItem ) ; } else { //Use object for ( const key in value ) { if ( ! value . hasOwnProperty ( key ) ) { continue ; } const val = value [ key ] ; addItem ( val , key ) ; } } parts . unshift ( this . getLengthBuffer ( propCounter ) ) ; return Buffer . concat ( parts ) ; } ; this . encodeUdt = function ( value , udtInfo ) { const parts = [ ] ; let totalLength = 0 ; for ( let i = 0 ; i < udtInfo . fields . length ; i ++ ) { const field = udtInfo . fields [ i ] ; const item = this . encode ( value [ field . name ] , field . type ) ; if ( ! item ) { parts . push ( nullValueBuffer ) ; totalLength += 4 ; continue ; } if ( item === types . unset ) { parts . push ( unsetValueBuffer ) ; totalLength += 4 ; continue ; } const lengthBuffer = utils . allocBufferUnsafe ( 4 ) ; lengthBuffer . writeInt32BE ( item . length , 0 ) ; parts . push ( lengthBuffer ) ; parts . push ( item ) ; totalLength += item . length + 4 ; } return Buffer . concat ( parts , totalLength ) ; } ; this . encodeTuple = function ( value , tupleInfo ) { const parts = [ ] ; let totalLength = 0 ; for ( let i = 0 ; i < tupleInfo . length ; i ++ ) { const type = tupleInfo [ i ] ; const item = this . encode ( value . get ( i ) , type ) ; if ( ! item ) { parts . push ( nullValueBuffer ) ; totalLength += 4 ; continue ; } if ( item === types . unset ) { parts . push ( unsetValueBuffer ) ; totalLength += 4 ; continue ; } const lengthBuffer = utils . allocBufferUnsafe ( 4 ) ; lengthBuffer . writeInt32BE ( item . length , 0 ) ; parts . push ( lengthBuffer ) ; parts . push ( item ) ; totalLength += item . length + 4 ; } return Buffer . concat ( parts , totalLength ) ; } ; /**
   * If not provided, it uses the array of buffers or the parameters and hints to build the routingKey
   * @param {Array} params
   * @param {ExecutionOptions} execOptions
   * @param [keys] parameter keys and positions in the params array
   * @throws TypeError
   * @internal
   * @ignore
   */ this . setRoutingKeyFromUser = function ( params , execOptions , keys ) { let totalLength = 0 ; const userRoutingKey = execOptions . getRoutingKey ( ) ; if ( util . isArray ( userRoutingKey ) ) { if ( userRoutingKey . length === 1 ) { execOptions . setRoutingKey ( userRoutingKey [ 0 ] ) ; return ; } // Its a composite routing key totalLength = 0 ; for ( let i = 0 ; i < userRoutingKey . length ; i ++ ) { const item = userRoutingKey [ i ] ; if ( ! item ) { // Invalid routing key part provided by the user, clear the value execOptions . setRoutingKey ( null ) ; return ; } totalLength += item . length + 3 ; } execOptions . setRoutingKey ( concatRoutingKey ( userRoutingKey , totalLength ) ) ; return ; } // If routingKey is present, ensure it is a Buffer, Token, or TokenRange.  Otherwise throw an error. if ( userRoutingKey ) { if ( userRoutingKey instanceof Buffer || userRoutingKey instanceof token . Token || userRoutingKey instanceof token . TokenRange ) { return ; } throw new TypeError ( ` ${ util . inspect ( userRoutingKey ) } ` + ` ` ) ; } // If no params are present, return as routing key cannot be determined. if ( ! params || params . length === 0 ) { return ; } let routingIndexes = execOptions . getRoutingIndexes ( ) ; if ( execOptions . getRoutingNames ( ) ) { routingIndexes = execOptions . getRoutingNames ( ) . map ( k => keys [ k ] ) ; } if ( ! routingIndexes ) { return ; } const parts = [ ] ; const hints = execOptions . getHints ( ) || utils . emptyArray ; const encodeParam = ! keys ? ( i => this . encode ( params [ i ] , hints [ i ] ) ) : ( i => this . encode ( params [ i ] . value , hints [ i ] ) ) ; try { totalLength = this . _encodeRoutingKeyParts ( parts , routingIndexes , encodeParam ) ; } catch ( e ) { // There was an error encoding a parameter that is part of the routing key, // ignore now to fail afterwards } if ( totalLength === 0 ) { return ; } execOptions . setRoutingKey ( concatRoutingKey ( parts , totalLength ) ) ; } ; /**
   * Sets the routing key in the options based on the prepared statement metadata.
   * @param {Object} meta Prepared metadata
   * @param {Array} params Array of parameters
   * @param {ExecutionOptions} execOptions
   * @throws TypeError
   * @internal
   * @ignore
   */ this . setRoutingKeyFromMeta = function ( meta , params , execOptions ) { const routingIndexes = execOptions . getRoutingIndexes ( ) ; if ( ! routingIndexes ) { return ; } const parts = new Array ( routingIndexes . length ) ; const encodeParam = i => { const columnInfo = meta . columns [ i ] ; return this . encode ( params [ i ] , columnInfo ? columnInfo . type : null ) ; } ; let totalLength = 0 ; try { totalLength = this . _encodeRoutingKeyParts ( parts , routingIndexes , encodeParam ) ; } catch ( e ) { // There was an error encoding a parameter that is part of the routing key, // ignore now to fail afterwards } if ( totalLength === 0 ) { return ; } execOptions . setRoutingKey ( concatRoutingKey ( parts , totalLength ) ) ; } ; /**
   * @param {Array} parts
   * @param {Array} routingIndexes
   * @param {Function} encodeParam
   * @returns {Number} The total length
   * @private
   */ this . _encodeRoutingKeyParts = function ( parts , routingIndexes , encodeParam ) { let totalLength = 0 ; for ( let i = 0 ; i < routingIndexes . length ; i ++ ) { const paramIndex = routingIndexes [ i ] ; if ( paramIndex === undefined ) { // Bad input from the user, ignore return 0 ; } const item = encodeParam ( paramIndex ) ; if ( item === null || item === undefined || item === types . unset ) { // The encoded partition key should an instance of Buffer // Let it fail later in the pipeline for null/undefined parameter values return 0 ; } // Per each part of the routing key, 3 extra bytes are needed totalLength += item . length + 3 ; parts [ i ] = item ; } return totalLength ; } ; /**
   * Parses a CQL name string into data type information
   * @param {String} keyspace
   * @param {String} typeName
   * @param {Number} startIndex
   * @param {Number|null} length
   * @param {Function} udtResolver
   * @param {Function} callback Callback invoked with err and  {{code: number, info: Object|Array|null, options: {frozen: Boolean}}}
   * @internal
   * @ignore
   */ this . parseTypeName = function ( keyspace , typeName , startIndex , length , udtResolver , callback ) { startIndex = startIndex || 0 ; if ( ! length ) { length = typeName . length ; } const dataType = { code : 0 , info : null , options : { frozen : false } } ; let innerTypes ; if ( typeName . indexOf ( "'" , startIndex ) === startIndex ) { //If quoted, this is a custom type. dataType . info = typeName . substr ( startIndex + 1 , length - 2 ) ; return callback ( null , dataType ) ; } if ( ! length ) { length = typeName . length ; } if ( typeName . indexOf ( cqlNames . frozen , startIndex ) === startIndex ) { //Remove the frozen token startIndex += cqlNames . frozen . length + 1 ; length -= cqlNames . frozen . length + 2 ; dataType . options . frozen = true ; } if ( typeName . indexOf ( cqlNames . list , startIndex ) === startIndex ) { //move cursor across the name and bypass the angle brackets startIndex += cqlNames . list . length + 1 ; length -= cqlNames . list . length + 2 ; innerTypes = parseParams ( typeName , startIndex , length , '<' , '>' ) ; if ( innerTypes . length !== 1 ) { return callback ( new TypeError ( 'Not a valid type ' + typeName ) ) ; } dataType . code = dataTypes . list ; return this . parseTypeName ( keyspace , innerTypes [ 0 ] , 0 , null , udtResolver , function ( err , childType ) { if ( err ) { return callback ( err ) ; } dataType . info = childType ; callback ( null , dataType ) ; } ) ; } if ( typeName . indexOf ( cqlNames . set , startIndex ) === startIndex ) { //move cursor across the name and bypass the angle brackets startIndex += cqlNames . set . length + 1 ; length -= cqlNames . set . length + 2 ; innerTypes = parseParams ( typeName , startIndex , length , '<' , '>' ) ; if ( innerTypes . length !== 1 ) { return callback ( new TypeError ( 'Not a valid type ' + typeName ) ) ; } dataType . code = dataTypes . set ; return this . parseTypeName ( keyspace , innerTypes [ 0 ] , 0 , null , udtResolver , function ( err , childType ) { if ( err ) { return callback ( err ) ; } dataType . info = childType ; callback ( null , dataType ) ; } ) ; } if ( typeName . indexOf ( cqlNames . map , startIndex ) === startIndex ) { //move cursor across the name and bypass the angle brackets startIndex += cqlNames . map . length + 1 ; length -= cqlNames . map . length + 2 ; innerTypes = parseParams ( typeName , startIndex , length , '<' , '>' ) ; //It should contain the key and value types if ( innerTypes . length !== 2 ) { return callback ( new TypeError ( 'Not a valid type ' + typeName ) ) ; } dataType . code = dataTypes . map ; return this . _parseChildTypes ( keyspace , dataType , innerTypes , udtResolver , callback ) ; } if ( typeName . indexOf ( cqlNames . tuple , startIndex ) === startIndex ) { //move cursor across the name and bypass the angle brackets startIndex += cqlNames . tuple . length + 1 ; length -= cqlNames . tuple . length + 2 ; innerTypes = parseParams ( typeName , startIndex , length , '<' , '>' ) ; if ( innerTypes . length < 1 ) { throw new TypeError ( 'Not a valid type ' + typeName ) ; } dataType . code = dataTypes . tuple ; return this . _parseChildTypes ( keyspace , dataType , innerTypes , udtResolver , callback ) ; } const quoted = typeName . indexOf ( '"' , startIndex ) === startIndex ; if ( quoted ) { //Remove quotes startIndex ++ ; length -= 2 ; } //Quick check if its a single type if ( startIndex > 0 ) { typeName = typeName . substr ( startIndex , length ) ; } // Un-escape double quotes if quoted. if ( quoted ) { typeName = typeName . replace ( '""' , '"' ) ; } const typeCode = dataTypes [ typeName ] ; if ( typeof typeCode === 'number' ) { dataType . code = typeCode ; return callback ( null , dataType ) ; } if ( typeName === cqlNames . duration ) { dataType . info = durationTypeName ; return callback ( null , dataType ) ; } if ( typeName === cqlNames . empty ) { //set as custom dataType . info = 'empty' ; return callback ( null , dataType ) ; } udtResolver ( keyspace , typeName , function ( err , udtInfo ) { if ( err ) { return callback ( err ) ; } if ( udtInfo ) { dataType . code = dataTypes . udt ; dataType . info = udtInfo ; return callback ( null , dataType ) ; } callback ( new TypeError ( 'Not a valid type "' + typeName + '"' ) ) ; } ) ; } ; /**
   * @param {String} keyspace
   * @param dataType
   * @param {Array} typeNames
   * @param {Function} udtResolver
   * @param {Function} callback
   * @private
   */ this . _parseChildTypes = function ( keyspace , dataType , typeNames , udtResolver , callback ) { const self = this ; utils . mapSeries ( typeNames , function ( name , next ) { self . parseTypeName ( keyspace , name . trim ( ) , 0 , null , udtResolver , next ) ; } , function ( err , childTypes ) { if ( err ) { return callback ( err ) ; } dataType . info = childTypes ; callback ( null , dataType ) ; } ) ; } ; /**
   * Parses a Cassandra fully-qualified class name string into data type information
   * @param {String} typeName
   * @param {Number} [startIndex]
   * @param {Number} [length]
   * @throws TypeError
   * @returns {{code: number, info: Object|Array|null, options: {frozen: Boolean, reversed: Boolean}}}
   * @internal
   * @ignore
   */ this . parseFqTypeName = function ( typeName , startIndex , length ) { const dataType = { code : 0 , info : null , options : { reversed : false , frozen : false } } ; startIndex = startIndex || 0 ; let innerTypes ; if ( ! length ) { length = typeName . length ; } if ( length > complexTypeNames . reversed . length && typeName . indexOf ( complexTypeNames . reversed ) === startIndex ) { //Remove the reversed token startIndex += complexTypeNames . reversed . length + 1 ; length -= complexTypeNames . reversed . length + 2 ; dataType . options . reversed = true ; } if ( length > complexTypeNames . frozen . length && typeName . indexOf ( complexTypeNames . frozen , startIndex ) === startIndex ) { //Remove the frozen token startIndex += complexTypeNames . frozen . length + 1 ; length -= complexTypeNames . frozen . length + 2 ; dataType . options . frozen = true ; } if ( typeName === complexTypeNames . empty ) { //set as custom dataType . info = 'empty' ; return dataType ; } //Quick check if its a single type if ( length <= singleFqTypeNamesLength ) { if ( startIndex > 0 ) { typeName = typeName . substr ( startIndex , length ) ; } const typeCode = singleTypeNames [ typeName ] ; if ( typeof typeCode === 'number' ) { dataType . code = typeCode ; return dataType ; } throw new TypeError ( 'Not a valid type "' + typeName + '"' ) ; } if ( typeName . indexOf ( complexTypeNames . list , startIndex ) === startIndex ) { //Its a list //org.apache.cassandra.db.marshal.ListType(innerType) //move cursor across the name and bypass the parenthesis startIndex += complexTypeNames . list . length + 1 ; length -= complexTypeNames . list . length + 2 ; innerTypes = parseParams ( typeName , startIndex , length ) ; if ( innerTypes . length !== 1 ) { throw new TypeError ( 'Not a valid type ' + typeName ) ; } dataType . code = dataTypes . list ; dataType . info = this . parseFqTypeName ( innerTypes [ 0 ] ) ; return dataType ; } if ( typeName . indexOf ( complexTypeNames . set , startIndex ) === startIndex ) { //Its a set //org.apache.cassandra.db.marshal.SetType(innerType) //move cursor across the name and bypass the parenthesis startIndex += complexTypeNames . set . length + 1 ; length -= complexTypeNames . set . length + 2 ; innerTypes = parseParams ( typeName , startIndex , length ) ; if ( innerTypes . length !== 1 ) { throw new TypeError ( 'Not a valid type ' + typeName ) ; } dataType . code = dataTypes . set ; dataType . info = this . parseFqTypeName ( innerTypes [ 0 ] ) ; return dataType ; } if ( typeName . indexOf ( complexTypeNames . map , startIndex ) === startIndex ) { //org.apache.cassandra.db.marshal.MapType(keyType,valueType) //move cursor across the name and bypass the parenthesis startIndex += complexTypeNames . map . length + 1 ; length -= complexTypeNames . map . length + 2 ; innerTypes = parseParams ( typeName , startIndex , length ) ; //It should contain the key and value types if ( innerTypes . length !== 2 ) { throw new TypeError ( 'Not a valid type ' + typeName ) ; } dataType . code = dataTypes . map ; dataType . info = [ this . parseFqTypeName ( innerTypes [ 0 ] ) , this . parseFqTypeName ( innerTypes [ 1 ] ) ] ; return dataType ; } if ( typeName . indexOf ( complexTypeNames . udt , startIndex ) === startIndex ) { //move cursor across the name and bypass the parenthesis startIndex += complexTypeNames . udt . length + 1 ; length -= complexTypeNames . udt . length + 2 ; return this . _parseUdtName ( typeName , startIndex , length ) ; } if ( typeName . indexOf ( complexTypeNames . tuple , startIndex ) === startIndex ) { //move cursor across the name and bypass the parenthesis startIndex += complexTypeNames . tuple . length + 1 ; length -= complexTypeNames . tuple . length + 2 ; innerTypes = parseParams ( typeName , startIndex , length ) ; if ( innerTypes . length < 1 ) { throw new TypeError ( 'Not a valid type ' + typeName ) ; } dataType . code = dataTypes . tuple ; dataType . info = innerTypes . map ( x => this . parseFqTypeName ( x ) ) ; return dataType ; } // Assume custom type if cannot be parsed up to this point. dataType . info = typeName . substr ( startIndex , length ) ; return dataType ; } ; /**
   * Parses type names with composites
   * @param {String} typesString
   * @returns {{types: Array, isComposite: Boolean, hasCollections: Boolean}}
   * @internal
   * @ignore
   */ this . parseKeyTypes = function ( typesString ) { let i = 0 ; let length = typesString . length ; const isComposite = typesString . indexOf ( complexTypeNames . composite ) === 0 ; if ( isComposite ) { i = complexTypeNames . composite . length + 1 ; length -- ; } const types = [ ] ; let startIndex = i ; let nested = 0 ; let inCollectionType = false ; let hasCollections = false ; //as collection types are not allowed, it is safe to split by , while ( ++ i < length ) { switch ( typesString [ i ] ) { case ',' : if ( nested > 0 ) { break ; } if ( inCollectionType ) { //remove type id startIndex = typesString . indexOf ( ':' , startIndex ) + 1 ; } types . push ( typesString . substring ( startIndex , i ) ) ; startIndex = i + 1 ; break ; case '(' : if ( nested === 0 && typesString . indexOf ( complexTypeNames . collection , startIndex ) === startIndex ) { inCollectionType = true ; hasCollections = true ; //skip collection type i ++ ; startIndex = i ; break ; } nested ++ ; break ; case ')' : if ( inCollectionType && nested === 0 ) { types . push ( typesString . substring ( typesString . indexOf ( ':' , startIndex ) + 1 , i ) ) ; startIndex = i + 1 ; break ; } nested -- ; break ; } } if ( startIndex < length ) { types . push ( typesString . substring ( startIndex , length ) ) ; } return { types : types . map ( name => this . parseFqTypeName ( name ) ) , hasCollections : hasCollections , isComposite : isComposite } ; } ; this . _parseUdtName = function ( typeName , startIndex , length ) { const udtParams = parseParams ( typeName , startIndex , length ) ; if ( udtParams . length < 2 ) { //It should contain at least the keyspace, name of the udt and a type throw new TypeError ( 'Not a valid type ' + typeName ) ; } const dataType = { code : dataTypes . udt , info : null } ; const udtInfo = { keyspace : udtParams [ 0 ] , name : utils . allocBufferFromString ( udtParams [ 1 ] , 'hex' ) . toString ( ) , fields : [ ] } ; for ( let i = 2 ; i < udtParams . length ; i ++ ) { const p = udtParams [ i ] ; const separatorIndex = p . indexOf ( ':' ) ; const fieldType = this . parseFqTypeName ( p , separatorIndex + 1 , p . length - ( separatorIndex + 1 ) ) ; udtInfo . fields . push ( { name : utils . allocBufferFromString ( p . substr ( 0 , separatorIndex ) , 'hex' ) . toString ( ) , type : fieldType } ) ; } dataType . info = udtInfo ; return dataType ; } ; customDecoders [ durationTypeName ] = this . decodeDuration ; customEncoders [ durationTypeName ] = this . encodeDuration ; }
Declares the privileged instance members.
@private
Declares the privileged instance members .