VarBuffer.js

Filename	Percent	Threshold	Total	Covered	Uncovered
src/consumers/VarBuffer.js	96.58%	80%	146	141	5

// @ts-check
// SPDX-License-Identifier: Zlib
// SPDX-FileCopyrightText: 2016 Sylvain Fargier
// SPDX-Created: 2016-11-08T14:04:02+01:00
// SPDX-FileContributor: Author: Sylvain Fargier <fargie_s> <fargier.sylvain@gmail.com>

"use strict";

class VarBuffer {
  /**
   * @param {?(Buffer|number)=} buf
   */
  constructor(buf) {
    this.length = 0;
    if (Number.isInteger(buf)) {
      /* @ts-ignore: checked above */
      this._buffer = Buffer.allocUnsafe(buf);
    }
    else if (buf instanceof Buffer) {
      this._buffer = buf;
      this.length = buf.length;
    }
    else {
      this._buffer = Buffer.allocUnsafe(VarBuffer.BUF_SZ);
    }
  }

  reset() {
    this.length = 0;
  }

  /**
   * @param {Buffer} data
   */
  add(data) {
    while (data.length > this._buffer.length - this.length) {
      this._enlarge();
    }
    data.copy(this._buffer, this.length, 0);
    this.length += data.length;
  }

  /** @return {Buffer} */
  buffer() {
    return this._buffer.slice(0, this.length);
  }

  /**
   * @param {number} start
   * @param {number} [end]
   * @return {Buffer}
   */
  slice(start, end) {
    return this._buffer.slice(start, end ?? this.length);
  }

  /** @return {number} */
  reserved() {
    return this._buffer.length;
  }

  /** @param {number} size */
  resize(size) {
    while (size > this._buffer.length) {
      this._enlarge();
    }
    this.length = size;
  }

  /**
   * @brief remove the first elements of the buffer
   * @param {number} [n=1]
   */
  shift(n = 1) {
    if (this.length === 0 || !Number.isInteger(n) || n < 1) { return; }
    if (n > this.length) { n = this.length; }
    const remainder = this.slice(n);
    this.reset();
    if (remainder.length > 0) { this.add(remainder); }
  }

  /**
   * @brief copy part of a buffer at a specific offset
   * @param  {Buffer|VarBuffer} target destination buffer
   * @param  {number} targetStart target start offset
   * @param  {number} sourceStart source (this) start offset
   * @param  {number} [sourceEnd] source end offset
   * @return {number} number of bytes copied
   */
  copy(target, targetStart, sourceStart, sourceEnd) {
    if (target instanceof VarBuffer) {
      target = target._buffer;
    }
    return this._buffer.copy(target, targetStart, sourceStart,
      (sourceEnd ?? this.length));
  }

  _enlarge() {
    var old = this._buffer;
    this._buffer = Buffer.allocUnsafe(this._buffer.length * 2);
    old.copy(this._buffer, 0, 0, this.length);
  }
}

VarBuffer.BUF_SZ = 2048;

export default VarBuffer;

[{"file":"src/consumers/VarBuffer.js","line":13,"character":9,"text":"length","kind":1},{"file":"src/consumers/VarBuffer.js","line":16,"character":11,"text":"_buffer","kind":1},{"file":"src/consumers/VarBuffer.js","line":19,"character":11,"text":"_buffer","kind":1},{"file":"src/consumers/VarBuffer.js","line":20,"character":11,"text":"length","kind":1},{"file":"src/consumers/VarBuffer.js","line":23,"character":11,"text":"_buffer","kind":1}]

TypeScript Coverage Report generated by type-coverage and typescript-coverage-report at Sun, 30 Jun 2024 01:34:16 GMT

TypeScript coverage report