123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869 |
- 'use strict'
- const tape = require('tape')
- const crypto = require('crypto')
- const fs = require('fs')
- const path = require('path')
- const BufferList = require('../')
- const { Buffer } = require('buffer')
- const encodings =
- ('hex utf8 utf-8 ascii binary base64' +
- (process.browser ? '' : ' ucs2 ucs-2 utf16le utf-16le')).split(' ')
- require('./indexOf')
- require('./isBufferList')
- require('./convert')
- tape('single bytes from single buffer', function (t) {
- const bl = new BufferList()
- bl.append(Buffer.from('abcd'))
- t.equal(bl.length, 4)
- t.equal(bl.get(-1), undefined)
- t.equal(bl.get(0), 97)
- t.equal(bl.get(1), 98)
- t.equal(bl.get(2), 99)
- t.equal(bl.get(3), 100)
- t.equal(bl.get(4), undefined)
- t.end()
- })
- tape('single bytes from multiple buffers', function (t) {
- const bl = new BufferList()
- bl.append(Buffer.from('abcd'))
- bl.append(Buffer.from('efg'))
- bl.append(Buffer.from('hi'))
- bl.append(Buffer.from('j'))
- t.equal(bl.length, 10)
- t.equal(bl.get(0), 97)
- t.equal(bl.get(1), 98)
- t.equal(bl.get(2), 99)
- t.equal(bl.get(3), 100)
- t.equal(bl.get(4), 101)
- t.equal(bl.get(5), 102)
- t.equal(bl.get(6), 103)
- t.equal(bl.get(7), 104)
- t.equal(bl.get(8), 105)
- t.equal(bl.get(9), 106)
- t.end()
- })
- tape('multi bytes from single buffer', function (t) {
- const bl = new BufferList()
- bl.append(Buffer.from('abcd'))
- t.equal(bl.length, 4)
- t.equal(bl.slice(0, 4).toString('ascii'), 'abcd')
- t.equal(bl.slice(0, 3).toString('ascii'), 'abc')
- t.equal(bl.slice(1, 4).toString('ascii'), 'bcd')
- t.equal(bl.slice(-4, -1).toString('ascii'), 'abc')
- t.end()
- })
- tape('multi bytes from single buffer (negative indexes)', function (t) {
- const bl = new BufferList()
- bl.append(Buffer.from('buffer'))
- t.equal(bl.length, 6)
- t.equal(bl.slice(-6, -1).toString('ascii'), 'buffe')
- t.equal(bl.slice(-6, -2).toString('ascii'), 'buff')
- t.equal(bl.slice(-5, -2).toString('ascii'), 'uff')
- t.end()
- })
- tape('multiple bytes from multiple buffers', function (t) {
- const bl = new BufferList()
- bl.append(Buffer.from('abcd'))
- bl.append(Buffer.from('efg'))
- bl.append(Buffer.from('hi'))
- bl.append(Buffer.from('j'))
- t.equal(bl.length, 10)
- t.equal(bl.slice(0, 10).toString('ascii'), 'abcdefghij')
- t.equal(bl.slice(3, 10).toString('ascii'), 'defghij')
- t.equal(bl.slice(3, 6).toString('ascii'), 'def')
- t.equal(bl.slice(3, 8).toString('ascii'), 'defgh')
- t.equal(bl.slice(5, 10).toString('ascii'), 'fghij')
- t.equal(bl.slice(-7, -4).toString('ascii'), 'def')
- t.end()
- })
- tape('multiple bytes from multiple buffer lists', function (t) {
- const bl = new BufferList()
- bl.append(new BufferList([Buffer.from('abcd'), Buffer.from('efg')]))
- bl.append(new BufferList([Buffer.from('hi'), Buffer.from('j')]))
- t.equal(bl.length, 10)
- t.equal(bl.slice(0, 10).toString('ascii'), 'abcdefghij')
- t.equal(bl.slice(3, 10).toString('ascii'), 'defghij')
- t.equal(bl.slice(3, 6).toString('ascii'), 'def')
- t.equal(bl.slice(3, 8).toString('ascii'), 'defgh')
- t.equal(bl.slice(5, 10).toString('ascii'), 'fghij')
- t.end()
- })
- // same data as previous test, just using nested constructors
- tape('multiple bytes from crazy nested buffer lists', function (t) {
- const bl = new BufferList()
- bl.append(new BufferList([
- new BufferList([
- new BufferList(Buffer.from('abc')),
- Buffer.from('d'),
- new BufferList(Buffer.from('efg'))
- ]),
- new BufferList([Buffer.from('hi')]),
- new BufferList(Buffer.from('j'))
- ]))
- t.equal(bl.length, 10)
- t.equal(bl.slice(0, 10).toString('ascii'), 'abcdefghij')
- t.equal(bl.slice(3, 10).toString('ascii'), 'defghij')
- t.equal(bl.slice(3, 6).toString('ascii'), 'def')
- t.equal(bl.slice(3, 8).toString('ascii'), 'defgh')
- t.equal(bl.slice(5, 10).toString('ascii'), 'fghij')
- t.end()
- })
- tape('append accepts arrays of Buffers', function (t) {
- const bl = new BufferList()
- bl.append(Buffer.from('abc'))
- bl.append([Buffer.from('def')])
- bl.append([Buffer.from('ghi'), Buffer.from('jkl')])
- bl.append([Buffer.from('mnop'), Buffer.from('qrstu'), Buffer.from('vwxyz')])
- t.equal(bl.length, 26)
- t.equal(bl.slice().toString('ascii'), 'abcdefghijklmnopqrstuvwxyz')
- t.end()
- })
- tape('append accepts arrays of Uint8Arrays', function (t) {
- const bl = new BufferList()
- bl.append(new Uint8Array([97, 98, 99]))
- bl.append([Uint8Array.from([100, 101, 102])])
- bl.append([new Uint8Array([103, 104, 105]), new Uint8Array([106, 107, 108])])
- bl.append([new Uint8Array([109, 110, 111, 112]), new Uint8Array([113, 114, 115, 116, 117]), new Uint8Array([118, 119, 120, 121, 122])])
- t.equal(bl.length, 26)
- t.equal(bl.slice().toString('ascii'), 'abcdefghijklmnopqrstuvwxyz')
- t.end()
- })
- tape('append accepts arrays of BufferLists', function (t) {
- const bl = new BufferList()
- bl.append(Buffer.from('abc'))
- bl.append([new BufferList('def')])
- bl.append(new BufferList([Buffer.from('ghi'), new BufferList('jkl')]))
- bl.append([Buffer.from('mnop'), new BufferList([Buffer.from('qrstu'), Buffer.from('vwxyz')])])
- t.equal(bl.length, 26)
- t.equal(bl.slice().toString('ascii'), 'abcdefghijklmnopqrstuvwxyz')
- t.end()
- })
- tape('append chainable', function (t) {
- const bl = new BufferList()
- t.ok(bl.append(Buffer.from('abcd')) === bl)
- t.ok(bl.append([Buffer.from('abcd')]) === bl)
- t.ok(bl.append(new BufferList(Buffer.from('abcd'))) === bl)
- t.ok(bl.append([new BufferList(Buffer.from('abcd'))]) === bl)
- t.end()
- })
- tape('append chainable (test results)', function (t) {
- const bl = new BufferList('abc')
- .append([new BufferList('def')])
- .append(new BufferList([Buffer.from('ghi'), new BufferList('jkl')]))
- .append([Buffer.from('mnop'), new BufferList([Buffer.from('qrstu'), Buffer.from('vwxyz')])])
- t.equal(bl.length, 26)
- t.equal(bl.slice().toString('ascii'), 'abcdefghijklmnopqrstuvwxyz')
- t.end()
- })
- tape('consuming from multiple buffers', function (t) {
- const bl = new BufferList()
- bl.append(Buffer.from('abcd'))
- bl.append(Buffer.from('efg'))
- bl.append(Buffer.from('hi'))
- bl.append(Buffer.from('j'))
- t.equal(bl.length, 10)
- t.equal(bl.slice(0, 10).toString('ascii'), 'abcdefghij')
- bl.consume(3)
- t.equal(bl.length, 7)
- t.equal(bl.slice(0, 7).toString('ascii'), 'defghij')
- bl.consume(2)
- t.equal(bl.length, 5)
- t.equal(bl.slice(0, 5).toString('ascii'), 'fghij')
- bl.consume(1)
- t.equal(bl.length, 4)
- t.equal(bl.slice(0, 4).toString('ascii'), 'ghij')
- bl.consume(1)
- t.equal(bl.length, 3)
- t.equal(bl.slice(0, 3).toString('ascii'), 'hij')
- bl.consume(2)
- t.equal(bl.length, 1)
- t.equal(bl.slice(0, 1).toString('ascii'), 'j')
- t.end()
- })
- tape('complete consumption', function (t) {
- const bl = new BufferList()
- bl.append(Buffer.from('a'))
- bl.append(Buffer.from('b'))
- bl.consume(2)
- t.equal(bl.length, 0)
- t.equal(bl._bufs.length, 0)
- t.end()
- })
- tape('test readUInt8 / readInt8', function (t) {
- const buf1 = Buffer.alloc(1)
- const buf2 = Buffer.alloc(3)
- const buf3 = Buffer.alloc(3)
- const bl = new BufferList()
- buf1[0] = 0x1
- buf2[1] = 0x3
- buf2[2] = 0x4
- buf3[0] = 0x23
- buf3[1] = 0x42
- bl.append(buf1)
- bl.append(buf2)
- bl.append(buf3)
- t.equal(bl.readUInt8(), 0x1)
- t.equal(bl.readUInt8(2), 0x3)
- t.equal(bl.readInt8(2), 0x3)
- t.equal(bl.readUInt8(3), 0x4)
- t.equal(bl.readInt8(3), 0x4)
- t.equal(bl.readUInt8(4), 0x23)
- t.equal(bl.readInt8(4), 0x23)
- t.equal(bl.readUInt8(5), 0x42)
- t.equal(bl.readInt8(5), 0x42)
- t.end()
- })
- tape('test readUInt16LE / readUInt16BE / readInt16LE / readInt16BE', function (t) {
- const buf1 = Buffer.alloc(1)
- const buf2 = Buffer.alloc(3)
- const buf3 = Buffer.alloc(3)
- const bl = new BufferList()
- buf1[0] = 0x1
- buf2[1] = 0x3
- buf2[2] = 0x4
- buf3[0] = 0x23
- buf3[1] = 0x42
- bl.append(buf1)
- bl.append(buf2)
- bl.append(buf3)
- t.equal(bl.readUInt16BE(), 0x0100)
- t.equal(bl.readUInt16LE(), 0x0001)
- t.equal(bl.readUInt16BE(2), 0x0304)
- t.equal(bl.readUInt16LE(2), 0x0403)
- t.equal(bl.readInt16BE(2), 0x0304)
- t.equal(bl.readInt16LE(2), 0x0403)
- t.equal(bl.readUInt16BE(3), 0x0423)
- t.equal(bl.readUInt16LE(3), 0x2304)
- t.equal(bl.readInt16BE(3), 0x0423)
- t.equal(bl.readInt16LE(3), 0x2304)
- t.equal(bl.readUInt16BE(4), 0x2342)
- t.equal(bl.readUInt16LE(4), 0x4223)
- t.equal(bl.readInt16BE(4), 0x2342)
- t.equal(bl.readInt16LE(4), 0x4223)
- t.end()
- })
- tape('test readUInt32LE / readUInt32BE / readInt32LE / readInt32BE', function (t) {
- const buf1 = Buffer.alloc(1)
- const buf2 = Buffer.alloc(3)
- const buf3 = Buffer.alloc(3)
- const bl = new BufferList()
- buf1[0] = 0x1
- buf2[1] = 0x3
- buf2[2] = 0x4
- buf3[0] = 0x23
- buf3[1] = 0x42
- bl.append(buf1)
- bl.append(buf2)
- bl.append(buf3)
- t.equal(bl.readUInt32BE(), 0x01000304)
- t.equal(bl.readUInt32LE(), 0x04030001)
- t.equal(bl.readUInt32BE(2), 0x03042342)
- t.equal(bl.readUInt32LE(2), 0x42230403)
- t.equal(bl.readInt32BE(2), 0x03042342)
- t.equal(bl.readInt32LE(2), 0x42230403)
- t.end()
- })
- tape('test readUIntLE / readUIntBE / readIntLE / readIntBE', function (t) {
- const buf1 = Buffer.alloc(1)
- const buf2 = Buffer.alloc(3)
- const buf3 = Buffer.alloc(3)
- const bl = new BufferList()
- buf2[0] = 0x2
- buf2[1] = 0x3
- buf2[2] = 0x4
- buf3[0] = 0x23
- buf3[1] = 0x42
- buf3[2] = 0x61
- bl.append(buf1)
- bl.append(buf2)
- bl.append(buf3)
- t.equal(bl.readUIntBE(1, 1), 0x02)
- t.equal(bl.readUIntBE(1, 2), 0x0203)
- t.equal(bl.readUIntBE(1, 3), 0x020304)
- t.equal(bl.readUIntBE(1, 4), 0x02030423)
- t.equal(bl.readUIntBE(1, 5), 0x0203042342)
- t.equal(bl.readUIntBE(1, 6), 0x020304234261)
- t.equal(bl.readUIntLE(1, 1), 0x02)
- t.equal(bl.readUIntLE(1, 2), 0x0302)
- t.equal(bl.readUIntLE(1, 3), 0x040302)
- t.equal(bl.readUIntLE(1, 4), 0x23040302)
- t.equal(bl.readUIntLE(1, 5), 0x4223040302)
- t.equal(bl.readUIntLE(1, 6), 0x614223040302)
- t.equal(bl.readIntBE(1, 1), 0x02)
- t.equal(bl.readIntBE(1, 2), 0x0203)
- t.equal(bl.readIntBE(1, 3), 0x020304)
- t.equal(bl.readIntBE(1, 4), 0x02030423)
- t.equal(bl.readIntBE(1, 5), 0x0203042342)
- t.equal(bl.readIntBE(1, 6), 0x020304234261)
- t.equal(bl.readIntLE(1, 1), 0x02)
- t.equal(bl.readIntLE(1, 2), 0x0302)
- t.equal(bl.readIntLE(1, 3), 0x040302)
- t.equal(bl.readIntLE(1, 4), 0x23040302)
- t.equal(bl.readIntLE(1, 5), 0x4223040302)
- t.equal(bl.readIntLE(1, 6), 0x614223040302)
- t.end()
- })
- tape('test readFloatLE / readFloatBE', function (t) {
- const buf1 = Buffer.alloc(1)
- const buf2 = Buffer.alloc(3)
- const buf3 = Buffer.alloc(3)
- const bl = new BufferList()
- buf1[0] = 0x01
- buf2[1] = 0x00
- buf2[2] = 0x00
- buf3[0] = 0x80
- buf3[1] = 0x3f
- bl.append(buf1)
- bl.append(buf2)
- bl.append(buf3)
- const canonical = Buffer.concat([buf1, buf2, buf3])
- t.equal(bl.readFloatLE(), canonical.readFloatLE())
- t.equal(bl.readFloatBE(), canonical.readFloatBE())
- t.equal(bl.readFloatLE(2), canonical.readFloatLE(2))
- t.equal(bl.readFloatBE(2), canonical.readFloatBE(2))
- t.end()
- })
- tape('test readDoubleLE / readDoubleBE', function (t) {
- const buf1 = Buffer.alloc(1)
- const buf2 = Buffer.alloc(3)
- const buf3 = Buffer.alloc(10)
- const bl = new BufferList()
- buf1[0] = 0x01
- buf2[1] = 0x55
- buf2[2] = 0x55
- buf3[0] = 0x55
- buf3[1] = 0x55
- buf3[2] = 0x55
- buf3[3] = 0x55
- buf3[4] = 0xd5
- buf3[5] = 0x3f
- bl.append(buf1)
- bl.append(buf2)
- bl.append(buf3)
- const canonical = Buffer.concat([buf1, buf2, buf3])
- t.equal(bl.readDoubleBE(), canonical.readDoubleBE())
- t.equal(bl.readDoubleLE(), canonical.readDoubleLE())
- t.equal(bl.readDoubleBE(2), canonical.readDoubleBE(2))
- t.equal(bl.readDoubleLE(2), canonical.readDoubleLE(2))
- t.end()
- })
- tape('test toString', function (t) {
- const bl = new BufferList()
- bl.append(Buffer.from('abcd'))
- bl.append(Buffer.from('efg'))
- bl.append(Buffer.from('hi'))
- bl.append(Buffer.from('j'))
- t.equal(bl.toString('ascii', 0, 10), 'abcdefghij')
- t.equal(bl.toString('ascii', 3, 10), 'defghij')
- t.equal(bl.toString('ascii', 3, 6), 'def')
- t.equal(bl.toString('ascii', 3, 8), 'defgh')
- t.equal(bl.toString('ascii', 5, 10), 'fghij')
- t.end()
- })
- tape('test toString encoding', function (t) {
- const bl = new BufferList()
- const b = Buffer.from('abcdefghij\xff\x00')
- bl.append(Buffer.from('abcd'))
- bl.append(Buffer.from('efg'))
- bl.append(Buffer.from('hi'))
- bl.append(Buffer.from('j'))
- bl.append(Buffer.from('\xff\x00'))
- encodings.forEach(function (enc) {
- t.equal(bl.toString(enc), b.toString(enc), enc)
- })
- t.end()
- })
- tape('uninitialized memory', function (t) {
- const secret = crypto.randomBytes(256)
- for (let i = 0; i < 1e6; i++) {
- const clone = Buffer.from(secret)
- const bl = new BufferList()
- bl.append(Buffer.from('a'))
- bl.consume(-1024)
- const buf = bl.slice(1)
- if (buf.indexOf(clone) !== -1) {
- t.fail(`Match (at ${i})`)
- break
- }
- }
- t.end()
- })
- !process.browser && tape('test stream', function (t) {
- const random = crypto.randomBytes(65534)
- const bl = new BufferList((err, buf) => {
- t.ok(Buffer.isBuffer(buf))
- t.ok(err === null)
- t.ok(random.equals(bl.slice()))
- t.ok(random.equals(buf.slice()))
- bl.pipe(fs.createWriteStream('/tmp/bl_test_rnd_out.dat'))
- .on('close', function () {
- const rndhash = crypto.createHash('md5').update(random).digest('hex')
- const md5sum = crypto.createHash('md5')
- const s = fs.createReadStream('/tmp/bl_test_rnd_out.dat')
- s.on('data', md5sum.update.bind(md5sum))
- s.on('end', function () {
- t.equal(rndhash, md5sum.digest('hex'), 'woohoo! correct hash!')
- t.end()
- })
- })
- })
- fs.writeFileSync('/tmp/bl_test_rnd.dat', random)
- fs.createReadStream('/tmp/bl_test_rnd.dat').pipe(bl)
- })
- tape('instantiation with Buffer', function (t) {
- const buf = crypto.randomBytes(1024)
- const buf2 = crypto.randomBytes(1024)
- let b = BufferList(buf)
- t.equal(buf.toString('hex'), b.slice().toString('hex'), 'same buffer')
- b = BufferList([buf, buf2])
- t.equal(b.slice().toString('hex'), Buffer.concat([buf, buf2]).toString('hex'), 'same buffer')
- t.end()
- })
- tape('test String appendage', function (t) {
- const bl = new BufferList()
- const b = Buffer.from('abcdefghij\xff\x00')
- bl.append('abcd')
- bl.append('efg')
- bl.append('hi')
- bl.append('j')
- bl.append('\xff\x00')
- encodings.forEach(function (enc) {
- t.equal(bl.toString(enc), b.toString(enc))
- })
- t.end()
- })
- tape('test Number appendage', function (t) {
- const bl = new BufferList()
- const b = Buffer.from('1234567890')
- bl.append(1234)
- bl.append(567)
- bl.append(89)
- bl.append(0)
- encodings.forEach(function (enc) {
- t.equal(bl.toString(enc), b.toString(enc))
- })
- t.end()
- })
- tape('write nothing, should get empty buffer', function (t) {
- t.plan(3)
- BufferList(function (err, data) {
- t.notOk(err, 'no error')
- t.ok(Buffer.isBuffer(data), 'got a buffer')
- t.equal(0, data.length, 'got a zero-length buffer')
- t.end()
- }).end()
- })
- tape('unicode string', function (t) {
- t.plan(2)
- const inp1 = '\u2600'
- const inp2 = '\u2603'
- const exp = inp1 + ' and ' + inp2
- const bl = BufferList()
- bl.write(inp1)
- bl.write(' and ')
- bl.write(inp2)
- t.equal(exp, bl.toString())
- t.equal(Buffer.from(exp).toString('hex'), bl.toString('hex'))
- })
- tape('should emit finish', function (t) {
- const source = BufferList()
- const dest = BufferList()
- source.write('hello')
- source.pipe(dest)
- dest.on('finish', function () {
- t.equal(dest.toString('utf8'), 'hello')
- t.end()
- })
- })
- tape('basic copy', function (t) {
- const buf = crypto.randomBytes(1024)
- const buf2 = Buffer.alloc(1024)
- const b = BufferList(buf)
- b.copy(buf2)
- t.equal(b.slice().toString('hex'), buf2.toString('hex'), 'same buffer')
- t.end()
- })
- tape('copy after many appends', function (t) {
- const buf = crypto.randomBytes(512)
- const buf2 = Buffer.alloc(1024)
- const b = BufferList(buf)
- b.append(buf)
- b.copy(buf2)
- t.equal(b.slice().toString('hex'), buf2.toString('hex'), 'same buffer')
- t.end()
- })
- tape('copy at a precise position', function (t) {
- const buf = crypto.randomBytes(1004)
- const buf2 = Buffer.alloc(1024)
- const b = BufferList(buf)
- b.copy(buf2, 20)
- t.equal(b.slice().toString('hex'), buf2.slice(20).toString('hex'), 'same buffer')
- t.end()
- })
- tape('copy starting from a precise location', function (t) {
- const buf = crypto.randomBytes(10)
- const buf2 = Buffer.alloc(5)
- const b = BufferList(buf)
- b.copy(buf2, 0, 5)
- t.equal(b.slice(5).toString('hex'), buf2.toString('hex'), 'same buffer')
- t.end()
- })
- tape('copy in an interval', function (t) {
- const rnd = crypto.randomBytes(10)
- const b = BufferList(rnd) // put the random bytes there
- const actual = Buffer.alloc(3)
- const expected = Buffer.alloc(3)
- rnd.copy(expected, 0, 5, 8)
- b.copy(actual, 0, 5, 8)
- t.equal(actual.toString('hex'), expected.toString('hex'), 'same buffer')
- t.end()
- })
- tape('copy an interval between two buffers', function (t) {
- const buf = crypto.randomBytes(10)
- const buf2 = Buffer.alloc(10)
- const b = BufferList(buf)
- b.append(buf)
- b.copy(buf2, 0, 5, 15)
- t.equal(b.slice(5, 15).toString('hex'), buf2.toString('hex'), 'same buffer')
- t.end()
- })
- tape('shallow slice across buffer boundaries', function (t) {
- const bl = new BufferList(['First', 'Second', 'Third'])
- t.equal(bl.shallowSlice(3, 13).toString(), 'stSecondTh')
- t.end()
- })
- tape('shallow slice within single buffer', function (t) {
- t.plan(2)
- const bl = new BufferList(['First', 'Second', 'Third'])
- t.equal(bl.shallowSlice(5, 10).toString(), 'Secon')
- t.equal(bl.shallowSlice(7, 10).toString(), 'con')
- t.end()
- })
- tape('shallow slice single buffer', function (t) {
- t.plan(3)
- const bl = new BufferList(['First', 'Second', 'Third'])
- t.equal(bl.shallowSlice(0, 5).toString(), 'First')
- t.equal(bl.shallowSlice(5, 11).toString(), 'Second')
- t.equal(bl.shallowSlice(11, 16).toString(), 'Third')
- })
- tape('shallow slice with negative or omitted indices', function (t) {
- t.plan(4)
- const bl = new BufferList(['First', 'Second', 'Third'])
- t.equal(bl.shallowSlice().toString(), 'FirstSecondThird')
- t.equal(bl.shallowSlice(5).toString(), 'SecondThird')
- t.equal(bl.shallowSlice(5, -3).toString(), 'SecondTh')
- t.equal(bl.shallowSlice(-8).toString(), 'ondThird')
- })
- tape('shallow slice does not make a copy', function (t) {
- t.plan(1)
- const buffers = [Buffer.from('First'), Buffer.from('Second'), Buffer.from('Third')]
- const bl = (new BufferList(buffers)).shallowSlice(5, -3)
- buffers[1].fill('h')
- buffers[2].fill('h')
- t.equal(bl.toString(), 'hhhhhhhh')
- })
- tape('shallow slice with 0 length', function (t) {
- t.plan(1)
- const buffers = [Buffer.from('First'), Buffer.from('Second'), Buffer.from('Third')]
- const bl = (new BufferList(buffers)).shallowSlice(0, 0)
- t.equal(bl.length, 0)
- })
- tape('shallow slice with 0 length from middle', function (t) {
- t.plan(1)
- const buffers = [Buffer.from('First'), Buffer.from('Second'), Buffer.from('Third')]
- const bl = (new BufferList(buffers)).shallowSlice(10, 10)
- t.equal(bl.length, 0)
- })
- tape('duplicate', function (t) {
- t.plan(2)
- const bl = new BufferList('abcdefghij\xff\x00')
- const dup = bl.duplicate()
- t.equal(bl.prototype, dup.prototype)
- t.equal(bl.toString('hex'), dup.toString('hex'))
- })
- tape('destroy no pipe', function (t) {
- t.plan(2)
- const bl = new BufferList('alsdkfja;lsdkfja;lsdk')
- bl.destroy()
- t.equal(bl._bufs.length, 0)
- t.equal(bl.length, 0)
- })
- tape('destroy with error', function (t) {
- t.plan(3)
- const bl = new BufferList('alsdkfja;lsdkfja;lsdk')
- const err = new Error('kaboom')
- bl.destroy(err)
- bl.on('error', function (_err) {
- t.equal(_err, err)
- })
- t.equal(bl._bufs.length, 0)
- t.equal(bl.length, 0)
- })
- !process.browser && tape('destroy with pipe before read end', function (t) {
- t.plan(2)
- const bl = new BufferList()
- fs.createReadStream(path.join(__dirname, '/test.js'))
- .pipe(bl)
- bl.destroy()
- t.equal(bl._bufs.length, 0)
- t.equal(bl.length, 0)
- })
- !process.browser && tape('destroy with pipe before read end with race', function (t) {
- t.plan(2)
- const bl = new BufferList()
- fs.createReadStream(path.join(__dirname, '/test.js'))
- .pipe(bl)
- setTimeout(function () {
- bl.destroy()
- setTimeout(function () {
- t.equal(bl._bufs.length, 0)
- t.equal(bl.length, 0)
- }, 500)
- }, 500)
- })
- !process.browser && tape('destroy with pipe after read end', function (t) {
- t.plan(2)
- const bl = new BufferList()
- fs.createReadStream(path.join(__dirname, '/test.js'))
- .on('end', onEnd)
- .pipe(bl)
- function onEnd () {
- bl.destroy()
- t.equal(bl._bufs.length, 0)
- t.equal(bl.length, 0)
- }
- })
- !process.browser && tape('destroy with pipe while writing to a destination', function (t) {
- t.plan(4)
- const bl = new BufferList()
- const ds = new BufferList()
- fs.createReadStream(path.join(__dirname, '/test.js'))
- .on('end', onEnd)
- .pipe(bl)
- function onEnd () {
- bl.pipe(ds)
- setTimeout(function () {
- bl.destroy()
- t.equals(bl._bufs.length, 0)
- t.equals(bl.length, 0)
- ds.destroy()
- t.equals(bl._bufs.length, 0)
- t.equals(bl.length, 0)
- }, 100)
- }
- })
- !process.browser && tape('handle error', function (t) {
- t.plan(2)
- fs.createReadStream('/does/not/exist').pipe(BufferList(function (err, data) {
- t.ok(err instanceof Error, 'has error')
- t.notOk(data, 'no data')
- }))
- })
|