var assert = require('assert'); var OffsetBuffer = require('../'); describe('OffsetBuffer', function() { var o; beforeEach(function() { o = new OffsetBuffer(); }); describe('.take()', function() { it('should return empty buffer', function() { var b = new Buffer('hello world'); o.push(b); var r = o.take(0); assert.equal(r.length, 0); assert.equal(o.size, b.length); }); it('should return the first buffer itself', function() { var b = new Buffer('hello world'); o.push(b); var r = o.take(b.length); assert(r === b); assert(o.isEmpty()); }); it('should return the slice of the buffer ', function() { var b = new Buffer('hello world'); o.push(b); assert.equal(o.take(5).toString(), 'hello'); assert.equal(o.take(1).toString(), ' '); assert.equal(o.take(5).toString(), 'world'); assert(o.isEmpty()); }); it('should concat buffers', function() { o.push(new Buffer('hello')); o.push(new Buffer(' ')); o.push(new Buffer('world!')); assert.equal(o.take(11).toString(), 'hello world'); assert.equal(o.take(1).toString(), '!'); assert(o.isEmpty()); }); }); describe('.skip', function() { it('should skip bytes', function() { o.push(new Buffer('hello ')); o.push(new Buffer('world')); o.push(new Buffer(' oh gosh')); assert.equal(o.take(2).toString(), 'he'); o.skip(1); assert.equal(o.take(2).toString(), 'lo'); o.skip(1); assert.equal(o.take(2).toString(), 'wo'); o.skip(4); assert.equal(o.take(7).toString(), 'oh gosh'); assert(o.isEmpty()); }); }); describe('.peekUInt8', function() { it('should return and not move by one byte', function() { o.push(new Buffer([ 0x1, 0x2 ])); assert.equal(o.peekUInt8(), 1); assert.equal(o.readUInt8(), 1); assert.equal(o.peekUInt8(), 2); assert.equal(o.readUInt8(), 2); assert(o.isEmpty()); }); }); describe('.peekInt8', function() { it('should return signed number', function() { o.push(new Buffer([ 0x80 ])); assert.equal(o.peekInt8(), -128); assert.equal(o.readInt8(), -128); assert(o.isEmpty()); }); }); describe('.readUInt8', function() { it('should return and move by one byte', function() { o.push(new Buffer([ 0x1, 0x2 ])); o.push(new Buffer([ 0x3, 0x4 ])); assert.equal(o.readUInt8(), 1); assert.equal(o.readUInt8(), 2); assert.equal(o.readUInt8(), 3); assert.equal(o.readUInt8(), 4); assert(o.isEmpty()); }); }); describe('.readInt8', function() { it('should return signed number', function() { o.push(new Buffer([ 0x8f, 0x7f ])); assert.equal(o.readInt8(), -113); assert.equal(o.readInt8(), 127); assert(o.isEmpty()); }); }); describe('.readUInt16LE', function() { it('should return and move by two bytes', function() { o.push(new Buffer([ 0x1, 0x2, 0x3 ])); o.push(new Buffer([ 0x4, 0x5, 0x6 ])); assert.equal(o.readUInt16LE(), 0x0201); assert.equal(o.readUInt16LE(), 0x0403); assert.equal(o.readUInt16LE(), 0x0605); assert(o.isEmpty()); }); it('should return and move by two bytes (regression #1)', function() { o.push(new Buffer([ 0x1 ])); o.push(new Buffer([ 0x2, 0x3, 0x4 ])); assert.equal(o.readUInt16LE(), 0x0201); assert.equal(o.readUInt16LE(), 0x0403); assert(o.isEmpty()); }); }); describe('.readInt16LE', function() { it('should return signed number', function() { o.push(new Buffer([ 0x23, 0x81 ])); assert.equal(o.readInt16LE(), -32477); assert(o.isEmpty()); }); }); describe('.readUInt24LE', function() { it('should return and move by three bytes', function() { o.push(new Buffer([ 0x1, 0x2, 0x3, 0x4, 0x5 ])); o.push(new Buffer([ 0x6, 0x7 ])); o.push(new Buffer([ 0x8, 0x9 ])); assert.equal(o.readUInt24LE(), 0x030201); assert.equal(o.readUInt24LE(), 0x060504); assert.equal(o.readUInt24LE(), 0x090807); assert(o.isEmpty()); }); it('should return and move by three bytes (regression #1)', function() { o.push(new Buffer([ 0x1, 0x2 ])); o.push(new Buffer([ 0x3 ])); assert.equal(o.readUInt24LE(), 0x030201); assert.equal(o.buffers.length, 0); assert(o.isEmpty()); }); }); describe('.readInt24LE', function() { it('should return signed number', function() { o.push(new Buffer([ 0x23, 0x45, 0x81 ])); assert.equal(o.readInt24LE(), -8305373); assert(o.isEmpty()); }); }); describe('.readUInt32LE', function() { it('should return and move by four bytes', function() { o.push(new Buffer([ 0x1, 0x2, 0x3, 0x4, 0x5, 0x6, 0x7 ])); o.push(new Buffer([ 0x8, 0x9, 0xa ])); o.push(new Buffer([ 0xb, 0xc, 0xd ])); o.push(new Buffer([ 0xe, 0xf, 0x10 ])); assert.equal(o.readUInt32LE(), 0x04030201); assert.equal(o.readUInt32LE(), 0x08070605); assert.equal(o.readUInt32LE(), 0x0c0b0a09); assert.equal(o.readUInt32LE(), 0x100f0e0d); assert(o.isEmpty()); }); it('should return and move by four bytes (regression #1)', function() { o.push(new Buffer([ 0x1, 0x2, 0x3 ])); o.push(new Buffer([ 0x4 ])); assert.equal(o.readUInt32LE(), 0x04030201); assert.equal(o.buffers.length, 0); assert(o.isEmpty()); }); }); describe('.readInt32LE', function() { it('should return signed number', function() { o.push(new Buffer([ 0xff, 0xff, 0xff, 0xff ])); assert.equal(o.readInt32LE(), -1); assert(o.isEmpty()); }); }); describe('.readUInt16BE', function() { it('should return and move by two bytes', function() { o.push(new Buffer([ 0x1, 0x2, 0x3 ])); o.push(new Buffer([ 0x4, 0x5, 0x6 ])); assert.equal(o.readUInt16BE(), 0x0102); assert.equal(o.readUInt16BE(), 0x0304); assert.equal(o.readUInt16BE(), 0x0506); assert(o.isEmpty()); }); }); describe('.readInt16BE', function() { it('should return signed number', function() { o.push(new Buffer([ 0x81, 0x23 ])); assert.equal(o.readInt16BE(), -32477); assert(o.isEmpty()); }); }); describe('.readUInt24BE', function() { it('should return and move by three bytes', function() { o.push(new Buffer([ 0x1, 0x2, 0x3, 0x4, 0x5 ])); o.push(new Buffer([ 0x6, 0x7 ])); o.push(new Buffer([ 0x8, 0x9 ])); assert.equal(o.readUInt24BE(), 0x010203); assert.equal(o.readUInt24BE(), 0x040506); assert.equal(o.readUInt24BE(), 0x070809); assert(o.isEmpty()); }); }); describe('.readInt24BE', function() { it('should return signed number', function() { o.push(new Buffer([ 0x81, 0x45, 0x23 ])); assert.equal(o.readInt24BE(), -8305373); assert(o.isEmpty()); }); }); describe('.readUInt32BE', function() { it('should return and move by four bytes', function() { o.push(new Buffer([ 0x1, 0x2, 0x3, 0x4, 0x5, 0x6, 0x7 ])); o.push(new Buffer([ 0x8, 0x9, 0xa ])); o.push(new Buffer([ 0xb, 0xc, 0xd ])); o.push(new Buffer([ 0xe, 0xf, 0x10 ])); assert.equal(o.readUInt32BE(), 0x01020304); assert.equal(o.readUInt32BE(), 0x05060708); assert.equal(o.readUInt32BE(), 0x090a0b0c); assert.equal(o.readUInt32BE(), 0x0d0e0f10); assert(o.isEmpty()); }); it('should return positive values', function() { o.push(new Buffer([ 0xff, 0xff, 0xff, 0xff ])); assert.equal(o.readUInt32BE(), 0xffffffff); assert(o.isEmpty()); }); }); describe('.readInt32BE', function() { it('should return signed number', function() { o.push(new Buffer([ 0xff, 0xff, 0xff, 0xff ])); assert.equal(o.readInt32BE(), -1); assert(o.isEmpty()); }); }); describe('.has', function() { it('should properly check the amount of the remaining bytes', function() { o.push(new Buffer([ 1, 2, 3 ])); assert(o.has(3)); assert.equal(o.readUInt8(), 0x01); assert(!o.has(3)); assert(o.has(2)); assert.equal(o.readUInt16BE(), 0x0203); assert(!o.has(1)); }); }); });