feat(loki-buffer): varint test

Author: wq1818528

packages/loki-buffer/src/ByteArray.ts

@@ -145,7 +145,7 @@ export class ByteArray {
   }
 
   readFloat(): number {
-    const float = (this._data_.getFloat32(this._pos_) * 100) / 100;
+    const float = this._data_.getInt32(this._pos_) / 1000;
     this._pos_ += 4;
     return float;
   }
@@ -242,7 +242,7 @@ export class ByteArray {
   }
 
   writeLong(value: number): void {
-    if (value != 0 && (value > Number.MAX_VALUE || value << Number.MIN_VALUE)) {
+    if (value != 0 && (value > Number.MAX_VALUE || value < Number.MIN_VALUE)) {
       logError('writeLong error -- Out of bounds');
     }
     let head: number;
@@ -265,7 +265,8 @@ export class ByteArray {
 
   writeFloat(value: number): void {
     this.ensureWrite(this._pos_ + 4);
-    this._data_.setFloat32(this._pos_, value);
+    value = value * 1000;
+    this._data_.setInt32(this._pos_, value);
     this._pos_ += 4;
   }
 

packages/loki-buffer/src/compress.ts

@@ -66,7 +66,7 @@ export class Compress {
     return this._data_.getInt8(this._pos_);
   }
 
-  readUnsignedInt(): number {
+  readUInt(): number {
     const uInt = this._data_.getUint32(this._pos_);
     this._pos_ += 32;
     return Math.floor(uInt);
@@ -84,7 +84,7 @@ export class Compress {
     return short;
   }
 
-  readUnsignedShort(): number {
+  readUShort(): number {
     const value = this._data_.getUint16(this._pos_);
     this._pos_ += 16;
     return value;
@@ -120,7 +120,7 @@ export class Compress {
     this._pos_ += 32;
   }
 
-  writeUnsignedInt(value: number): void {
+  writeUInt(value: number): void {
     this.ensureWrite(this._pos_ + 32);
     this._data_.setUint32(this._pos_, value);
     this._pos_ += 32;
@@ -132,18 +132,12 @@ export class Compress {
     this._pos_ += 16;
   }
 
-  writeUnsignedShort(value: number): void {
+  writeUShort(value: number): void {
     this.ensureWrite(this._pos_ + 16);
     this._data_.setUint16(this._pos_, value);
     this._pos_ += 16;
   }
 
-  writeFloat(value: number): void {
-    this.ensureWrite(this._pos_ + 32);
-    this._data_.setFloat32(this._pos_, value);
-    this._pos_ += 32;
-  }
-
   writeDouble(value: number): void {
     this.ensureWrite(this._pos_ + 64);
     this._data_.setFloat64(this._pos_, value);
@@ -160,7 +154,7 @@ export class Compress {
   }
 }
 
-class CompressBytes {
+export class CompressBytes {
   public byteLength = 0;
   public pos = 0;
   public _buffer;
@@ -425,25 +419,6 @@ class CompressBytes {
     }
   }
 
-  setFloat32(pos: number, value: number): void {
-    this.pos = pos;
-    if (pos % 8 == 0 && pos / 8 <= this._buffer.length) {
-      this._idx++;
-      this._buffer[this._idx] = value;
-    } else if (pos % 8 == 0 && pos / 8 > this._buffer.length) {
-      let newBuffer = new Int8Array(this.byteLength * 1.5);
-      for (let i = 0; i < this.byteLength; i++) {
-        newBuffer[i] = this._buffer[i];
-      }
-      this.byteLength = this.byteLength * 1.5;
-    } else if (pos % 8 != 0) {
-      let i = value >> pos % 8;
-      this._buffer[this._idx] = (this._buffer[this._idx] + i) << pos % 8;
-      this._idx++;
-      this._buffer[this._idx] = value - i;
-    }
-  }
-
   setFloat64(pos: number, value: number): void {
     this.pos = pos;
     if (pos % 8 == 0 && pos / 8 <= this._buffer.length) {

packages/loki-buffer/test/blah.test.ts

@@ -1,16 +1,19 @@
 import { ByteArray } from '../src';
 
 test('blah', () => {
-  const writerBuf = new ArrayBuffer(30);
+  const writerBuf = new ArrayBuffer(100);
   const writer = new ByteArray(writerBuf);
   writer.writeBoolean(true);
   writer.writeByte(1);
   writer.writeDouble(2.1);
-  // writer.writeFloat(3.1);
+  writer.writeFloat(3.1);
   writer.writeInt(4);
   writer.writeShort(5);
   writer.writeBoolean(true);
+  writer.writeLong(123);
   writer.writeVarInt(1);
+  writer.writeVarInt(512); //1000000000 -> 11000000 00001000 -128 8
+  writer.writeVarLong(123);
   writer.writeVarLong(123);
   writer.writeString('hhh');
 
@@ -19,12 +22,18 @@ test('blah', () => {
   expect(reader.readBoolean()).toBe(true);
   expect(reader.readByte()).toBe(1);
   expect(reader.readDouble()).toBe(2.1);
-  // expect(reader.readFloat()).toBe(3.1);
+  expect(reader.readFloat()).toBe(3.1);
   expect(reader.readInt()).toBe(4);
   expect(reader.readShort()).toBe(5);
   expect(reader.readBoolean()).toBe(true);
+  expect(reader.readLong()).toBe(123);
   expect(reader.readVarInt()).toBe(1);
+
+  expect(reader.readByte()).toBe(-128);
+  expect(reader.readByte()).toBe(8);
+
   expect(reader.readVarLong()).toBe(123);
+  expect(reader.readUByte()).toBe(123);
   expect(reader.readString()).toBe('hhh');
 });